rj
/
ht
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

4 files update

Browse Source
webservice
calyrex 5 months ago
parent e45e532034
commit f8270f19b8
6 changed files with 75 additions and 38 deletions
Show Stats Download Patch File Download Diff File

3
secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/BY_EnterToJhrwMx.java
Unescape Escape View File

@ -69,6 +69,9 @@ public class BY_EnterToJhrwMx implements Action, EsbServerlessRpcRemoteInterface
TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源*/
long generate = IdGenerator.generate();
rs.executeSql(sql, poolname,generate);
// 写入流程提醒记录
String sql4 = "insert into e10_common.dbo.jhrwmxlog(id,mainid,rwbh,lcbid,zkjh,gzrw,zrr,jxzb,ts,ksrq,jsrq,yqrq,phr,ddr,qrr,csr,pid,glid,mxid,isdr,rwzt,requestid,request,rwbh2,lxsj,tdsj,rwlx,xmkp,yhry,rwjb,shr,jtyq,tbr,rbbm,ssgs,rwsm,fj,yfjd,xmbh,FtriggerFlag) (select id,mainid,rwbh,lcbid,zkjh,gzrw,zrr,jxzb,ts,ksrq,jsrq,yqrq,phr,ddr,qrr,csr,pid,glid,mxid,isdr,rwzt,0 as requestid,requestid as request,rwbh2,lxsj,tdsj,rwlx,xmkp,yhry,rwjb,shr,jtyq,tbr,rbbm,ssgs,rwsm,fj,yfjd,xmbh,0 as FtriggerFlag from jhrwmx where mxid<>0 and ISDR=0 AND cast(glid as varchar) = '" + glid + "') order by rwbh ";
logger_b053f378.info("sql4:" + sql4);

60
secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/BuQianKaAction.java
Unescape Escape View File

@ -119,13 +119,21 @@ public class BuQianKaAction extends BaseBean implements Action, EsbServerlessRpc
Punchreason = Util.null2String((String) mainTableDataMap.get("yyy2"));
TimeCardTime = TimeCardTime + " " + time;
Punchtype1 = Punchtype + "_2";
String sql = "insert into e10_common.dbo.buka_log(requestid,gh,punchreason,punchtype,TimeCardDate,TimeCardTime,createrId,BKRQ) values" + "(" + requestid + ",'" + GH + "','" + Punchreason + "','" + Punchtype1 + "','" + TimeCardDate + "','" + TimeCardTime + "','" + createrId + "','" + BKRQ + "')";
// String sql = "insert into e10_common.dbo.buka_log(requestid,gh,punchreason,punchtype,TimeCardDate,TimeCardTime,createrId,BKRQ) values" + "(" + requestid + ",'" + GH + "','" + Punchreason + "','" + Punchtype1 + "','" + TimeCardDate + "','" + TimeCardTime + "','" + createrId + "','" + BKRQ + "')";
// logger_f1f35583.info(String.valueOf("sql2:" + sql));
// String poolname_ae = CONN_TYPE.ebuilder.getType();
// /* *TODO 检测到insert语句 -> E9插入sql迁移到E10需要特殊处理请参考文档进行调整 https://www.e-cology.com.cn/sp/doc/docShare/1027709301045985331?tenantKey=t7akvdnf84
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源*/
// long generate = IdGenerator.generate();
// rs.executeSql(sql, poolname_ae,generate);
Long uf_CustomFlow_formId1 = commonDevUtil.getObjId("buka_log");
logger_f1f35583.info("uf_CustomFlow_formId = " + uf_CustomFlow_formId1);
SimpleEmployee currentEmployee = HrmContextUtil.getCurrentUser();
Long recodId = ebFormDataDubboService.addEmptyData(uf_CustomFlow_formId1, currentEmployee);
String sql = "update e10_common.dbo.buka_log set requestid = " + requestid + ",gh = '" + GH + "',punchreason='" + Punchreason + "',punchtype='" + Punchtype1 + "',TimeCardDate='" + TimeCardDate + "',TimeCardTime='" + TimeCardTime + "',createrId='" + createrId + "',BKRQ='" + BKRQ + "' where id = " + recodId+ " and delete_type = 0 ";
boolean b1 = rs.executeSql(sql, poolname);
logger_f1f35583.info(String.valueOf("sql2:" + sql));
String poolname_ae = CONN_TYPE.ebuilder.getType();
/* *TODO 检测到insert语句 -> E9插入sql迁移到E10需要特殊处理请参考文档进行调整 https://www.e-cology.com.cn/sp/doc/docShare/1027709301045985331?tenantKey=t7akvdnf84
TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源*/
long generate = IdGenerator.generate();
rs.executeSql(sql, poolname_ae,generate);
logger_f1f35583.info(String.valueOf("b1:" + b1));
}
}
logger_f1f35583.info(String.valueOf("sikz:" + mainTableDataMap.get("sikz")));
@ -138,13 +146,21 @@ public class BuQianKaAction extends BaseBean implements Action, EsbServerlessRpc
Punchreason = Util.null2String((String) mainTableDataMap.get("yyy" + (2 + i)));
TimeCardTime = TimeCardTime + " " + time;
Punchtype1 = Punchtype + "_" + i;
String sql = "insert into e10_common.dbo.buka_log(requestid,gh,punchreason,punchtype,TimeCardDate,TimeCardTime,createrId,BKRQ) values" + "(" + requestid + ",'" + GH + "','" + Punchreason + "','" + Punchtype1 + "','" + TimeCardDate + "','" + TimeCardTime + "','" + createrId + "','" + BKRQ + "')";
// String sql = "insert into e10_common.dbo.buka_log(requestid,gh,punchreason,punchtype,TimeCardDate,TimeCardTime,createrId,BKRQ) values" + "(" + requestid + ",'" + GH + "','" + Punchreason + "','" + Punchtype1 + "','" + TimeCardDate + "','" + TimeCardTime + "','" + createrId + "','" + BKRQ + "')";
// logger_f1f35583.info(String.valueOf("sql3:" + sql));
// String poolname_oa = CONN_TYPE.ebuilder.getType();
// /* *TODO 检测到insert语句 -> E9插入sql迁移到E10需要特殊处理请参考文档进行调整 https://www.e-cology.com.cn/sp/doc/docShare/1027709301045985331?tenantKey=t7akvdnf84
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源*/
// long generate = IdGenerator.generate();
// rs.executeSql(sql, poolname_oa,generate);
Long uf_CustomFlow_formId2 = commonDevUtil.getObjId("buka_log");
logger_f1f35583.info("uf_CustomFlow_formId = " + uf_CustomFlow_formId2);
SimpleEmployee currentEmployee = HrmContextUtil.getCurrentUser();
Long recodId = ebFormDataDubboService.addEmptyData(uf_CustomFlow_formId2, currentEmployee);
String sql = "update e10_common.dbo.buka_log set requestid = " + requestid + ",gh = '" + GH + "',punchreason='" + Punchreason + "',punchtype='" + Punchtype1 + "',TimeCardDate='" + TimeCardDate + "',TimeCardTime='" + TimeCardTime + "',createrId='" + createrId + "',BKRQ='" + BKRQ + "' where id = " + recodId+ " and delete_type = 0 ";
boolean b1 = rs.executeSql(sql, poolname);
logger_f1f35583.info(String.valueOf("sql3:" + sql));
String poolname_oa = CONN_TYPE.ebuilder.getType();
/* *TODO 检测到insert语句 -> E9插入sql迁移到E10需要特殊处理请参考文档进行调整 https://www.e-cology.com.cn/sp/doc/docShare/1027709301045985331?tenantKey=t7akvdnf84
TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源*/
long generate = IdGenerator.generate();
rs.executeSql(sql, poolname_oa,generate);
logger_f1f35583.info(String.valueOf("b1:" + b1));
}
}
}
@ -158,13 +174,21 @@ public class BuQianKaAction extends BaseBean implements Action, EsbServerlessRpc
Punchreason = Util.null2String((String) mainTableDataMap.get("yyy" + (6 + i)));
TimeCardTime = TimeCardTime + " " + time;
Punchtype1 = Punchtype + "_" + i;
String sql = "insert into e10_common.dbo.buka_log(requestid,gh,punchreason,punchtype,TimeCardDate,TimeCardTime,createrId,BKRQ) values" + "(" + requestid + ",'" + GH + "','" + Punchreason + "','" + Punchtype1 + "','" + TimeCardDate + "','" + TimeCardTime + "','" + createrId + "','" + BKRQ + "')";
// String sql = "insert into e10_common.dbo.buka_log(requestid,gh,punchreason,punchtype,TimeCardDate,TimeCardTime,createrId,BKRQ) values" + "(" + requestid + ",'" + GH + "','" + Punchreason + "','" + Punchtype1 + "','" + TimeCardDate + "','" + TimeCardTime + "','" + createrId + "','" + BKRQ + "')";
// logger_f1f35583.info(String.valueOf("sql4:" + sql));
// String poolname_31 = CONN_TYPE.ebuilder.getType();
// /* *TODO 检测到insert语句 -> E9插入sql迁移到E10需要特殊处理请参考文档进行调整 https://www.e-cology.com.cn/sp/doc/docShare/1027709301045985331?tenantKey=t7akvdnf84
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源*/
// long generate = IdGenerator.generate();
// rs.executeSql(sql, poolname_31,generate);
Long uf_CustomFlow_formId3 = commonDevUtil.getObjId("buka_log");
logger_f1f35583.info("uf_CustomFlow_formId = " + uf_CustomFlow_formId3);
SimpleEmployee currentEmployee = HrmContextUtil.getCurrentUser();
Long recodId = ebFormDataDubboService.addEmptyData(uf_CustomFlow_formId3, currentEmployee);
String sql = "update e10_common.dbo.buka_log set requestid = " + requestid + ",gh = '" + GH + "',punchreason='" + Punchreason + "',punchtype='" + Punchtype1 + "',TimeCardDate='" + TimeCardDate + "',TimeCardTime='" + TimeCardTime + "',createrId='" + createrId + "',BKRQ='" + BKRQ + "' where id = " + recodId+ " and delete_type = 0 ";
boolean b1 = rs.executeSql(sql, poolname);
logger_f1f35583.info(String.valueOf("sql4:" + sql));
String poolname_31 = CONN_TYPE.ebuilder.getType();
/* *TODO 检测到insert语句 -> E9插入sql迁移到E10需要特殊处理请参考文档进行调整 https://www.e-cology.com.cn/sp/doc/docShare/1027709301045985331?tenantKey=t7akvdnf84
TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源*/
long generate = IdGenerator.generate();
rs.executeSql(sql, poolname_31,generate);
logger_f1f35583.info(String.valueOf("b1:" + b1));
}
}
}

12
secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/CustomTeAction.java
Unescape Escape View File

@ -1,15 +1,12 @@
package com.weaver.seconddev.interfaces.workflow.action;
import com.alibaba.fastjson.JSON;
import com.weaver.authority.api.req.role.BatchAuthRoleReq;
import com.weaver.authority.api.rest.RemoteAuthorityRoleService;
import com.weaver.common.base.entity.result.WeaResult;
import com.weaver.common.hrm.util.HrmContextUtil;
import com.weaver.common.i18n.tool.util.I18nContextUtil;
import com.weaver.custom.configcenter.htsysjcmtConfig;
import com.weaver.ebuilder.form.client.ebform.data.EbFormDataDubboService;
import com.weaver.esb.api.rpc.EsbServerlessRpcRemoteInterface;
import com.weaver.framework.client.annotation.WeaverConfigCenter;
import com.weaver.framework.rpc.annotation.RpcReference;
import com.weaver.seconddev.interfaces.prop.ConfigProp;
import com.weaver.seconddev.interfaces.workflow.util.CommonDevUtil;
@ -17,22 +14,15 @@ import com.weaver.teams.domain.user.SimpleEmployee;
import com.weaver.verupgrade.conn.CONN_TYPE;
import com.weaver.verupgrade.conn.RecordSet;
import com.weaver.verupgrade.general.BaseBean;
import com.weaver.verupgrade.general.Util;
import com.weaver.verupgrade.interfaces.workflow.action.Action;
import com.weaver.verupgrade.soa.workflow.request.RequestInfo;
import com.weaver.verupgrade.workflow.request.RequestManager;
import lombok.Data;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.env.Environment;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@ -64,7 +54,7 @@ public class CustomTeAction extends BaseBean implements Action, EsbServerlessRpc
@Override
public WeaResult<Map<String, Object>> execute(Map<String, Object> params) {
logger.error("start CustomTeAction");
logger.error("lplysl_url == " + configProp.getLplysl_url());
// logger.error("lplysl_url == " + configProp.getLplysl_url());
logger.error("basePackage == " + basePackage);
logger.error("params = " + JSON.toJSONString(params));

2
secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/DoTheActionNew.java
Unescape Escape View File

@ -91,7 +91,6 @@ public class DoTheActionNew {
String csr = (String) mainMap.get("csr");
String ddr = (String) mainMap.get("ddr");
String qrr = (String) mainMap.get("qrr");
String sql = "insert into dbo.uf_zqjhrqfkxx (requestId,fksm,fj,fkrq,pid,zrr,ddr,csr,phr,qrr,formmodeid,modedatacreater) values (?,?,?,?,?,?,?,?,?,?,97,?)";
Object[] array = new Object[11];
array[0] = requestId;
array[1] = sm;
@ -106,6 +105,7 @@ public class DoTheActionNew {
array[10] = tbr;
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
String poolname ="";
String sql = "insert into dbo.uf_zqjhrqfkxx (requestId,fksm,fj,fkrq,pid,zrr,ddr,csr,phr,qrr,formmodeid,modedatacreater) values (?,?,?,?,?,?,?,?,?,?,97,?)";
rs.executeSql(sql, false, poolname, array);
String sql2 = "select * from uf_zqjhrqfkxx where pid = " + mxid;
RecordSet rs3 = I18nContextUtil.getBean(RecordSet.class);

2
secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/SCFAndEASApplyUserSyncAction.java
Unescape Escape View File

@ -199,7 +199,7 @@ public class SCFAndEASApplyUserSyncAction extends BaseBean implements Action, Es
rs.executeSql("insert into uf_applyUser(companycode,formmodeid,modedatacreater,modedatacreatertype,modedatacreatedate,modedatacreatetime," + "lclx,oafqr,oafqrgh,easfqr,easfqrgh,modeuuid) " + "values('" + companyCode + "'," + "'139'," + sqr + "," + "'0'," + "'" + currentdate + "'," + "'" + currenttime + "'," + list.get(i).get("lclx") + "," + list.get(i).get("oafqr") + ",'" + list.get(i).get("oafqrgh") + "'," + list.get(i).get("oafqr") + ",'" + list.get(i).get("oafqrgh") + "','" + uuid + // DiscountedInvoiceApplicationImpl 使用eas发起人
"')", poolname_2n,generate);
}
// rs.execute("insert into uf_applyUser(companycode,lclx,oafqr,oafqrgh,easfqr,easfqrgh) values('"+companyCode+"',"+list.get(i).get("lclx")+","+list.get(i).get("oafqr")+",'"+list.get(i).get("oafqrgh")+"',"+list.get(i).get("easfqr")+",'"+list.get(i).get("easfqrgh")+"')");
// rs.execute("F");
}
}
}

34
secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_SD_CREDIT_HANDLE_APPROVALAction.java
Unescape Escape View File

@ -1,10 +1,15 @@
package com.weaver.seconddev.interfaces.workflow.action;
import com.weaver.common.distribution.genid.IdGenerator;
import com.weaver.common.hrm.util.HrmContextUtil;
import com.weaver.ebuilder.form.client.ebform.data.EbFormDataDubboService;
import com.weaver.framework.rpc.annotation.RpcReference;
import com.weaver.seconddev.interfaces.crmoa.CRM_SyncUnFreezeTimesStub;
import com.weaver.seconddev.interfaces.crmoa.CRM_syncUnFreezeTimes;
import com.weaver.seconddev.interfaces.swfa.BillFieldUtil;
import com.weaver.common.i18n.tool.util.I18nContextUtil;
import com.weaver.seconddev.interfaces.workflow.util.CommonDevUtil;
import com.weaver.teams.domain.user.SimpleEmployee;
import com.weaver.verupgrade.conn.CONN_TYPE;
import java.lang.*;
import java.util.*;
@ -34,6 +39,12 @@ public class ZOA_SD_CREDIT_HANDLE_APPROVALAction extends BaseBean implements Act
@Autowired
private RequestInfo requestInfoTemp;
@Autowired
private CommonDevUtil commonDevUtil;
@RpcReference(group = "ebuilderform")
private EbFormDataDubboService ebFormDataDubboService;
@Autowired
private CRM_syncUnFreezeTimes freezeTimes ;
@ -150,13 +161,22 @@ public class ZOA_SD_CREDIT_HANDLE_APPROVALAction extends BaseBean implements Act
logger_d591fda6.info(String.valueOf("------------[state : " + result[0] + "][message : " + result[1] + "] ----------"));
logger_d591fda6.info(String.valueOf("------------do webservice CRM_syncUnFreezeTimes fail ----------"));
// 把数据写入中间表
String sql = "insert into HT_CRM_JDCS (REQUESTID,KHBM,XSZZ,SQRGH,SQRQ,CREATEDATE ) VALUES ('" + requestId + "','" + khbm + "','" + xszz + "','" + sqrgh + "','" + sqrq + "',GETDATE())";
logger_d591fda6.info(String.valueOf("写入中间表sql : " + sql));
String poolname_jj = CONN_TYPE.workflow.getType();
/* *TODO 检测到insert语句 -> E9插入sql迁移到E10需要特殊处理请参考文档进行调整 https://www.e-cology.com.cn/sp/doc/docShare/1027709301045985331?tenantKey=t7akvdnf84
TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源*/
long generate = IdGenerator.generate();
rs.executeSql(sql, poolname_jj,generate);
// String sql = "insert into HT_CRM_JDCS (REQUESTID,KHBM,XSZZ,SQRGH,SQRQ,CREATEDATE ) VALUES ('" + requestId + "','" + khbm + "','" + xszz + "','" + sqrgh + "','" + sqrq + "',GETDATE())";
// logger_d591fda6.info(String.valueOf("写入中间表sql : " + sql));
// String poolname_jj = CONN_TYPE.workflow.getType();
// /* *TODO 检测到insert语句 -> E9插入sql迁移到E10需要特殊处理请参考文档进行调整 https://www.e-cology.com.cn/sp/doc/docShare/1027709301045985331?tenantKey=t7akvdnf84
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源*/
// long generate = IdGenerator.generate();
// rs.executeSql(sql, poolname_jj,generate);
Long uf_CustomFlow_formId = commonDevUtil.getObjId("HT_CRM_JDCS");
logger_d591fda6.info("uf_CustomFlow_formId = " + uf_CustomFlow_formId);
SimpleEmployee currentEmployee = HrmContextUtil.getCurrentUser();
Long recodId = ebFormDataDubboService.addEmptyData(uf_CustomFlow_formId, currentEmployee);// 获取插入的空的建模id
String sql3 = "update e10_common.dbo.HT_CRM_JDCS set REQUESTID = '" + requestId + "',KHBM='" + khbm + "',XSZZ='" + xszz + "',SQRGH='" + sqrgh + "',SQRQ='" + sqrq + "',CREATEDATE=GETDATE() where id = " + recodId + " and delete_type = 0 ";
boolean b1 = rs.executeSql(sql3, poolname);
logger_d591fda6.info("sql3 = " + sql3);
logger_d591fda6.info("添加 = " + b1);
logger_d591fda6.info(String.valueOf("------------写入中间表 success ----------"));
} else {
// 成功

Write Preview
Loading…
Cancel
Save