diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/srmoa/CallSrmVenMatExtsSevices.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/srmoa/CallSrmVenMatExtsSevices.java index bc1ee3a..72801c9 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/srmoa/CallSrmVenMatExtsSevices.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/srmoa/CallSrmVenMatExtsSevices.java @@ -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(); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/AddVenMatExtsToSrmAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/AddVenMatExtsToSrmAction.java index ff64980..33bb891 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/AddVenMatExtsToSrmAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/AddVenMatExtsToSrmAction.java @@ -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]; diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/BY_EnterToJhrwMx.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/BY_EnterToJhrwMx.java index 6980d6d..3da79ac 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/BY_EnterToJhrwMx.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/BY_EnterToJhrwMx.java @@ -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(); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/BuQianKaAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/BuQianKaAction.java index 9d4a194..ef2e5e9 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/BuQianKaAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/BuQianKaAction.java @@ -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(); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/CheckGiftNumFromK3Action.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/CheckGiftNumFromK3Action.java index cc29dc3..c90a20b 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/CheckGiftNumFromK3Action.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/CheckGiftNumFromK3Action.java @@ -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 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))) {