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

gift

Browse Source
webservice
qijirenjian 6 months ago
parent 5bf7b6acea
commit af0e162317
5 changed files with 51 additions and 28 deletions
Show Stats Download Patch File Download Diff File

1
secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/srmoa/CallSrmVenMatExtsSevices.java
Unescape Escape View File

@ -14,6 +14,7 @@ public class CallSrmVenMatExtsSevices extends BaseBean {
public String[] call(VenMatExtsHandlerServiceServiceStub.VenMatExtsRusultIn param, String requestid) throws Exception {
logger_8da144ad.info(String.valueOf(requestid + " 调用接口------------------------开始"));
logger_8da144ad.info(String.valueOf(requestid + " param == " + param.toString()));
VenMatExtsHandlerServiceServiceStub stub = new VenMatExtsHandlerServiceServiceStub();
VenMatExtsHandlerServiceServiceStub.SRM_OA_VENMATEXTS_RESULTE res = new VenMatExtsHandlerServiceServiceStub.SRM_OA_VENMATEXTS_RESULTE();
VenMatExtsHandlerServiceServiceStub.SRM_OA_VENMATEXTS_RESULT sovr = new VenMatExtsHandlerServiceServiceStub.SRM_OA_VENMATEXTS_RESULT();

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

@ -212,7 +212,7 @@ public class AddVenMatExtsToSrmAction extends BaseBean implements Action, EsbSer
}
oainputvendor.setItems(item);
CallSrmVenMatExtsSevices service = new CallSrmVenMatExtsSevices();
logger_336cd654.info(requestId + "-------AddVenMatExtsToSrmAction请求数据----" + oainputvendor);
logger_336cd654.info(requestId + "-------AddVenMatExtsToSrmAction请求数据----" + oainputvendor.toString());
//
String[] str = service.call(oainputvendor, requestId);
String isTat = str[1];

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

@ -38,6 +38,9 @@ public class BY_EnterToJhrwMx implements Action, EsbServerlessRpcRemoteInterface
Long requestIdTemp = Long.parseLong(String.valueOf(requestInfoMap.getOrDefault("requestid", -1)));
Long userIdTemp = Long.parseLong(String.valueOf(requestInfoMap.getOrDefault("userid", -1)));
RequestInfo paramRequestInfo = requestInfoTemp.getRequestInfo(requestIdTemp, userIdTemp);
logger_b053f378.info("---------------- BY_EnterToJhrwMx start ---------------");
logger_b053f378.info("requestIdTemp:" + requestIdTemp);
logger_b053f378.info("userIdTemp:" + userIdTemp);
try {
String glid = "";
String rwbh2 = "";
@ -54,31 +57,34 @@ public class BY_EnterToJhrwMx implements Action, EsbServerlessRpcRemoteInterface
}
mainMap.put(name, value);
}
logger_b053f378.info("glid:" + glid);
logger_b053f378.info("rwbh2:" + rwbh2);
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
RecordSet rs3 = I18nContextUtil.getBean(RecordSet.class);
String sql = "insert into JhrwMx(isdr,id,mainid,rwbh,lcbid,zkjh,gzrw,zrr,jxzb,ts,ksrq,jsrq,phr,ddr,qrr,csr,pid,glid,mxid,rwzt,requestid,rwbh2,lxsj,tdsj,rwlx,xmkp,yhry,rwjb,shr,jtyq,tbr,rbbm,ssgs,rwsm,fj,yfjd,xmbh)select T1.ISDR,T1.MXID,T1.GLID,'" + rwbh2 + "' + T1.RWBH,T1.lcbid,T1.zkjh,T1.GZRW,T1.ZRR,T1.JXZB,T1.TS," + "T1.KSRQ,T1.JSRQ,T1.PHR,T1.DDR,T1.QRR,T1.CSR,(CASE T1.PID WHEN 0 THEN isnull(T1.lcbid,0) ELSE T1.PID END) as PID,cast(T1.GLID as varchar) as glid,T1.MXID,'执行中'," + "'" + paramRequestInfo.getRequestid() + "'," + "'" + Util.null2String((String) mainMap.get("rwbh")) + "'," + "'" + Util.null2String((String) mainMap.get("lxsj")) + "'," + "'" + Util.null2String((String) mainMap.get("tdsj")) + "'," + "'" + Util.null2String((String) mainMap.get("rwlx")) + "'," + "'" + Util.null2String((String) mainMap.get("xmkp")) + "'," + "'" + Util.null2String((String) mainMap.get("yhry")) + "'," + "'" + Util.null2String((String) mainMap.get("rwjb")) + "'," + "'" + Util.null2String((String) mainMap.get("shr")) + "'," + "'" + Util.null2String((String) mainMap.get("jtyq")) + "'," + "'" + Util.null2String((String) mainMap.get("tbr")) + "'," + "'" + Util.null2String((String) mainMap.get("rbbm")) + "'," + "'" + Util.null2String((String) mainMap.get("ssgs")) + "'," + "'" + Util.null2String((String) mainMap.get("rwsm")).replace("'", "''") + "'," + "'" + Util.null2String((String) mainMap.get("fj")) + "'," + "'" + Util.null2String((String) mainMap.get("yfjd")) + "'," + "'" + Util.null2String((String) mainMap.get("xmbh")) + "'" + "from JhrwLcmx T1 where t1.mxid<>0 and T1.ISDR=0 AND glid = '" + glid + "' order by rwbh";
this.log.info("sql:" + sql);
String poolname = CONN_TYPE.workflow.getType();
String sql = "insert into e10_common.dbo.JhrwMx(isdr,id,mainid,rwbh,lcbid,zkjh,gzrw,zrr,jxzb,ts,ksrq,jsrq,phr,ddr,qrr,csr,pid,glid,mxid,rwzt,requestid,rwbh2,lxsj,tdsj,rwlx,xmkp,yhry,rwjb,shr,jtyq,tbr,rbbm,ssgs,rwsm,fj,yfjd,xmbh)select T1.ISDR,T1.MXID,T1.GLID,'" + rwbh2 + "' + T1.RWBH,T1.lcbid,T1.zkjh,T1.GZRW,T1.ZRR,T1.JXZB,T1.TS," + "T1.KSRQ,T1.JSRQ,T1.PHR,T1.DDR,T1.QRR,T1.CSR,(CASE T1.PID WHEN 0 THEN isnull(T1.lcbid,0) ELSE T1.PID END) as PID,cast(T1.GLID as varchar) as glid,T1.MXID,'执行中'," + "'" + paramRequestInfo.getRequestid() + "'," + "'" + Util.null2String((String) mainMap.get("rwbh")) + "'," + "'" + Util.null2String((String) mainMap.get("lxsj")) + "'," + "'" + Util.null2String((String) mainMap.get("tdsj")) + "'," + "'" + Util.null2String((String) mainMap.get("rwlx")) + "'," + "'" + Util.null2String((String) mainMap.get("xmkp")) + "'," + "'" + Util.null2String((String) mainMap.get("yhry")) + "'," + "'" + Util.null2String((String) mainMap.get("rwjb")) + "'," + "'" + Util.null2String((String) mainMap.get("shr")) + "'," + "'" + Util.null2String((String) mainMap.get("jtyq")) + "'," + "'" + Util.null2String((String) mainMap.get("tbr")) + "'," + "'" + Util.null2String((String) mainMap.get("rbbm")) + "'," + "'" + Util.null2String((String) mainMap.get("ssgs")) + "'," + "'" + Util.null2String((String) mainMap.get("rwsm")).replace("'", "''") + "'," + "'" + Util.null2String((String) mainMap.get("fj")) + "'," + "'" + Util.null2String((String) mainMap.get("yfjd")) + "'," + "'" + Util.null2String((String) mainMap.get("xmbh")) + "'" + "from JhrwLcmx T1 where t1.mxid<>0 and T1.ISDR=0 AND glid = '" + glid + "' order by rwbh";
logger_b053f378.info("sql:" + sql);
String poolname = 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,generate);
// 写入流程提醒记录
String sql4 = "insert into 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 ";
this.log.info("sql4:" + sql4);
String poolname_11 = CONN_TYPE.workflow.getType();
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);
String poolname_11 = CONN_TYPE.ebuilder.getType();
/* *TODO 检测到insert语句 -> E9插入sql迁移到E10需要特殊处理请参考文档进行调整 https://www.e-cology.com.cn/sp/doc/docShare/1027709301045985331?tenantKey=t7akvdnf84
TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源*/
generate = IdGenerator.generate();
rs.executeSql(sql4, poolname_11,generate);
String poolname_ra = CONN_TYPE.workflow.getType();
String poolname_ra = CONN_TYPE.ebuilder.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs3.executeSql("delete from mission_change where id=" + glid, poolname_ra);
String poolname_gh = CONN_TYPE.workflow.getType();
rs3.executeSql("delete from e10_common.dbo.mission_change where id=" + glid, poolname_ra);
String poolname_gh = CONN_TYPE.ebuilder.getType();
/* *TODO 检测到insert语句 -> E9插入sql迁移到E10需要特殊处理请参考文档进行调整 https://www.e-cology.com.cn/sp/doc/docShare/1027709301045985331?tenantKey=t7akvdnf84
TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源*/
generate = IdGenerator.generate();
rs3.executeSql("insert into mission_change (id,mmode,mtype) values(" + glid + ",1,2)", poolname_gh,generate);
rs3.executeSql("insert into e10_common.dbo.mission_change (id,mmode,mtype) values(" + glid + ",1,2)", poolname_gh,generate);
RecordSet rs1 = I18nContextUtil.getBean(RecordSet.class);
/*
String sql1 = " update JhrwMx set pid=(select top 1 t2.pid from jhrwlcmx t2 where t2.mxid=mxid and T2.ISDR<>0 AND T2.glid = '" + glid + "')," +
@ -86,18 +92,20 @@ public class BY_EnterToJhrwMx implements Action, EsbServerlessRpcRemoteInterface
" isdr=(select top 1 t3.isdr from jhrwlcmx t3 where t3.mxid=mxid and T3.ISDR<>0 AND T3.glid = '" + glid + "')" +
" where mxid in (select mxid from jhrwlcmx where ISDR<>0 AND glid = '" + glid + "')";
*/
String sql1 = " update JhrwMx set pid=(select top 1 t2.pid from jhrwlcmx t2 where t2.mxid=mxid and T2.ISDR<>0 AND T2.glid = '" + glid + "')," + " glid=(cast(glid as varchar) + ',' + '" + glid + "')," + " isdr= '1' where mxid in (select mxid from jhrwlcmx where ISDR<>0 AND glid = '" + glid + "')";
this.log.info("sql1:" + sql1);
String poolname_m7 = CONN_TYPE.workflow.getType();
String sql1 = " update e10_common.dbo.JhrwMx set pid=(select top 1 t2.pid from jhrwlcmx t2 where t2.mxid=mxid and T2.ISDR<>0 AND T2.glid = '" + glid + "')," + " glid=(cast(glid as varchar) + ',' + '" + glid + "')," + " isdr= '1' where mxid in (select mxid from jhrwlcmx where ISDR<>0 AND glid = '" + glid + "')";
logger_b053f378.info("sql1:" + sql1);
String poolname_m7 = CONN_TYPE.ebuilder.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs1.executeSql(sql1, poolname_m7);
String poolname_p1 = CONN_TYPE.workflow.getType();
String poolname_p1 = CONN_TYPE.ebuilder.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs3.executeSql("delete from mission_change where id=" + glid, poolname_p1);
String poolname_in = CONN_TYPE.workflow.getType();
rs3.executeSql("delete from e10_common.dbo.mission_change where id=" + glid, poolname_p1);
String poolname_in = CONN_TYPE.ebuilder.getType();
/* *TODO 检测到insert语句 -> E9插入sql迁移到E10需要特殊处理请参考文档进行调整 https://www.e-cology.com.cn/sp/doc/docShare/1027709301045985331?tenantKey=t7akvdnf84
TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源*/
rs3.executeSql("insert into mission_change (id,mmode,mtype) values(" + glid + ",2,2)", poolname_in);
rs3.executeSql("insert into e10_common.dbo.mission_change (id,mmode,mtype) values(" + glid + ",2,2)", poolname_in);
logger_b053f378.info("---------------- BY_EnterToJhrwMx stop ---------------");
return WeaResult.success(getResultMapForAction(weaverResultMap, "result", "1", paramRequestInfo.getRequestManager()));
} catch (Exception e) {
e.printStackTrace();

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

@ -41,8 +41,8 @@ public class BuQianKaAction extends BaseBean implements Action, EsbServerlessRpc
String creater = request.getCreatorid();
logger_f1f35583.info(String.valueOf("creater:" + creater));
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String createsqlString = "select id from employee as hrmresource where lastname ='" + creater + "'";
String poolname = CONN_TYPE.workflow.getType();
String createsqlString = "select id from eteams.dbo.employee as hrmresource where lastname ='" + creater + "'";
String poolname = CONN_TYPE.hrm.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs.executeSql(createsqlString, poolname);
rs.next();
@ -75,6 +75,7 @@ public class BuQianKaAction extends BaseBean implements Action, EsbServerlessRpc
String TimeCardDate = "";
String TimeCardTime = "";
logger_f1f35583.info(String.valueOf("Punchtype:" + Punchtype));
logger_f1f35583.info(String.valueOf("liangkz:" + mainTableDataMap.get("liangkz")));
if (Util.null2String((String) mainTableDataMap.get("liangkz")).equals("1")) {
if (!Util.null2String((String) mainTableDataMap.get("yyy1")).equals("")) {
TimeCardTime = Util.null2String((String) mainTableDataMap.get("ldate1"));
@ -83,13 +84,15 @@ public class BuQianKaAction extends BaseBean implements Action, EsbServerlessRpc
TimeCardTime = TimeCardTime + " " + time;
Punchreason = Util.null2String((String) mainTableDataMap.get("yyy1"));
Punchtype1 = Punchtype + "_1";
String sql = "insert into buka_log(requestid,gh,punchreason,punchtype,TimeCardDate,TimeCardTime,createrId,BKRQ) values" + "(" + requestid + ",'" + GH + "','" + Punchreason + "','" + Punchtype1 + "','" + TimeCardDate + "','" + TimeCardTime + "','" + createrId + "','" + BKRQ + "')";
String poolname_z7 = CONN_TYPE.workflow.getType();
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("sql1:" + sql));
String poolname_z7 = 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_z7,generate);
}
logger_f1f35583.info(String.valueOf("yyy2:" + mainTableDataMap.get("yyy2")));
if (!Util.null2String((String) mainTableDataMap.get("yyy2")).equals("")) {
TimeCardTime = Util.null2String((String) mainTableDataMap.get("ldate2"));
String time = Util.null2String((String) mainTableDataMap.get("ltime2"));
@ -97,14 +100,16 @@ 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 buka_log(requestid,gh,punchreason,punchtype,TimeCardDate,TimeCardTime,createrId,BKRQ) values" + "(" + requestid + ",'" + GH + "','" + Punchreason + "','" + Punchtype1 + "','" + TimeCardDate + "','" + TimeCardTime + "','" + createrId + "','" + BKRQ + "')";
String poolname_ae = CONN_TYPE.workflow.getType();
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);
}
}
logger_f1f35583.info(String.valueOf("sikz:" + mainTableDataMap.get("sikz")));
if (Util.null2String((String) mainTableDataMap.get("sikz")).equals("1")) {
for (int i = 1; i <= 4; i++) {
if (!Util.null2String((String) mainTableDataMap.get("yyy" + (2 + i))).equals("")) {
@ -114,8 +119,9 @@ 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 buka_log(requestid,gh,punchreason,punchtype,TimeCardDate,TimeCardTime,createrId,BKRQ) values" + "(" + requestid + ",'" + GH + "','" + Punchreason + "','" + Punchtype1 + "','" + TimeCardDate + "','" + TimeCardTime + "','" + createrId + "','" + BKRQ + "')";
String poolname_oa = CONN_TYPE.workflow.getType();
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();
@ -123,6 +129,7 @@ public class BuQianKaAction extends BaseBean implements Action, EsbServerlessRpc
}
}
}
logger_f1f35583.info(String.valueOf("liukz:" + mainTableDataMap.get("liukz")));
if (Util.null2String((String) mainTableDataMap.get("liukz")).equals("1")) {
for (int i = 1; i <= 6; i++) {
if (!Util.null2String((String) mainTableDataMap.get("yyy" + (6 + i))).equals("")) {
@ -132,8 +139,9 @@ 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 buka_log(requestid,gh,punchreason,punchtype,TimeCardDate,TimeCardTime,createrId,BKRQ) values" + "(" + requestid + ",'" + GH + "','" + Punchreason + "','" + Punchtype1 + "','" + TimeCardDate + "','" + TimeCardTime + "','" + createrId + "','" + BKRQ + "')";
String poolname_31 = CONN_TYPE.workflow.getType();
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();
@ -141,6 +149,7 @@ public class BuQianKaAction extends BaseBean implements Action, EsbServerlessRpc
}
}
}
logger_f1f35583.info(String.valueOf("stop BuQianKaAction"));
return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, request.getRequestManager()));
} catch (Exception e) {
e.printStackTrace();

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

@ -35,10 +35,14 @@ public class CheckGiftNumFromK3Action extends BaseBean implements Action, EsbSer
Long requestIdTemp = Long.parseLong(String.valueOf(requestInfoMap.getOrDefault("requestid", -1)));
Long userIdTemp = Long.parseLong(String.valueOf(requestInfoMap.getOrDefault("userid", -1)));
RequestInfo requestinfo = requestInfoTemp.getRequestInfo(requestIdTemp, userIdTemp);
try {
String requestid = requestinfo.getRequestid();
try {
logger_33d4b5.info(String.valueOf("CheckGiftNumFromK3Action--start--" + requestid));
logger_33d4b5.info("requestIdTemp"+requestIdTemp);
logger_33d4b5.info("userIdTemp"+userIdTemp);
DetailTable[] detailtable = requestinfo.getDetailTableInfo().getDetailTable();
DetailTable dtq = detailtable[0];
Row[] sq = dtq.getRow();
@ -85,6 +89,7 @@ public class CheckGiftNumFromK3Action extends BaseBean implements Action, EsbSer
GiftQtyService service = new GiftQtyService();
Map<String, String> map = service.call(giftStockDt);
StringBuilder sb = new StringBuilder();
logger_33d4b5.info("code "+map.get("code"));
if ("1".equals(map.get("code"))) {
for (String key : slMap.keySet()) {
if ("0".equals(map.get(key))) {

Write Preview
Loading…
Cancel
Save