diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/htjt/workflow/hr/HrUtil.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/htjt/workflow/hr/HrUtil.java index b5bae4e..5cfae16 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/htjt/workflow/hr/HrUtil.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/htjt/workflow/hr/HrUtil.java @@ -36,11 +36,12 @@ public class HrUtil { String guid = ""; if (!"".equals(qjlb)) { // TODO 有参构造 :new RecordSetDataSource("hr") 实例化方式改变,请检查是否有对应有参实现 - RecordSetDataSource rsd = I18nContextUtil.getBean(RecordSetDataSource.class).setPoolname("hr"); +// RecordSetDataSource rsd = I18nContextUtil.getBean(RecordSetDataSource.class).setPoolname("hr"); + RecordSet rsd = I18nContextUtil.getBean(RecordSet.class); String sql = "select classGUID from ht_ATDATTENDANCECLASS where id=" + qjlb; String poolname = ""; // TODO E10必须指定poolname数据源 - rsd.executeSql(sql, poolname); + rsd.executeSql(sql, "hr"); if (rsd.next()) { guid = Util.null2String(rsd.getString("classGUID")); } diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/BlackListTempThawCheckAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/BlackListTempThawCheckAction.java index e8fa33f..9f50336 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/BlackListTempThawCheckAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/BlackListTempThawCheckAction.java @@ -46,7 +46,8 @@ public class BlackListTempThawCheckAction extends BaseBean implements Action, Es logger_454fb322.info(String.valueOf("BlackListTempThawCheckAction--start--" + requestid)); String wfid = request.getWorkflowid(); BillFieldUtil util = new BillFieldUtil(); - String table = util.getTablename(wfid); +// String table = util.getTablename(wfid); + String table = request.getRequestManager().getBillTableName(); Property[] properties = request.getMainTableInfo().getProperty(); Map map = new HashMap(); for (int i = 0; i < properties.length; i++) { diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ChuChaiShenQingNewAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ChuChaiShenQingNewAction.java index e62db65..088b217 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ChuChaiShenQingNewAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ChuChaiShenQingNewAction.java @@ -60,7 +60,7 @@ public class ChuChaiShenQingNewAction extends BaseBean implements Action, EsbSer String requestid = request.getRequestid(); String lastoperator = request.getLastoperator(); // TODO 有参构造 :new RecordSetDataSource("hr") 实例化方式改变,请检查是否有对应有参实现 - RecordSetDataSource rdsd = I18nContextUtil.getBean(RecordSetDataSource.class).setPoolname("hr"); + RecordSet rdsd = I18nContextUtil.getBean(RecordSet.class); RecordSet rs = I18nContextUtil.getBean(RecordSet.class); String workflowid = request.getWorkflowid(); String requestname = request.getRequestManager().getRequestname(); @@ -100,7 +100,7 @@ public class ChuChaiShenQingNewAction extends BaseBean implements Action, EsbSer String sql = "select classcode from e10_common.dbo.ht_ATDATTENDANCECLASS where ID='" + value + "'"; logger_fee0cda9.info("sql == " + sql ); - rdsd.executeSql(sql, poolname); + rdsd.executeSql(sql, "hr"); rdsd.next(); QJLB = Util.null2String(rdsd.getString("classcode")); logger_fee0cda9.info("QJLB == " + QJLB ); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/DidiYongCheAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/DidiYongCheAction.java index b974c06..8c25e3b 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/DidiYongCheAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/DidiYongCheAction.java @@ -94,10 +94,10 @@ public class DidiYongCheAction extends BaseBean implements Action, EsbServerless requestinfo.getRequestManager().setMessageid("ERROR"); requestinfo.getRequestManager().setMessagecontent("滴滴返回错误信息：" + message); } else { - String content = getPropValue("htportaloaUrl", "didiremindtext"); +// String content = getPropValue("htportaloaUrl", "didiremindtext"); // Map urlmap = new HashMap(); // urlmap.put("msgurl", getPropValue("htportaloaUrl","didiremindurl")); - String dataid = getPropValue("htportaloaUrl", "didireminddataid"); +// String dataid = getPropValue("htportaloaUrl", "didireminddataid"); // InterfaceUtil.sendMsg(sendlist,","+dataid+",", "", content,16,urlmap); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/HTGD_MES_NonStandardAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/HTGD_MES_NonStandardAction.java index 62615ce..1f0e94a 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/HTGD_MES_NonStandardAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/HTGD_MES_NonStandardAction.java @@ -52,7 +52,8 @@ public class HTGD_MES_NonStandardAction extends BaseBean implements Action, EsbS // 工作流ID String workFlowId = requestInfo.getWorkflowid(); BillFieldUtil util = new BillFieldUtil(); - String tablename = util.getTablename(workFlowId); +// String tablename = util.getTablename(workFlowId); + String tablename = requestInfo.getRequestManager().getBillTableName(); try { String requestName = requestInfo.getRequestManager().getRequestname(); String creatorId = requestInfo.getCreatorid(); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/HTGD_MES_SC03Action.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/HTGD_MES_SC03Action.java index b9076e7..0ed3168 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/HTGD_MES_SC03Action.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/HTGD_MES_SC03Action.java @@ -159,7 +159,8 @@ public class HTGD_MES_SC03Action extends BaseBean implements Action, EsbServerle logger_1ea91e04.info(String.valueOf(requestId + "-HTGD_MES_SC03Action info:" + ret[0] + "-" + ret[1])); if (!"S".equals(ret[0])) { BillFieldUtil util = new BillFieldUtil(); - String tablename = util.getTablename(workFlowId); +// String tablename = util.getTablename(workFlowId); + String tablename = requestinfo.getRequestManager().getBillTableName(); RecordSet rs = I18nContextUtil.getBean(RecordSet.class); String poolname_ig = CONN_TYPE.workflow.getType(); // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/HTGD_MES_SpeedFixAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/HTGD_MES_SpeedFixAction.java index 68dee45..7a56165 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/HTGD_MES_SpeedFixAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/HTGD_MES_SpeedFixAction.java @@ -115,7 +115,8 @@ public class HTGD_MES_SpeedFixAction extends BaseBean implements Action, EsbServ logger_d0d39a5f.info(String.valueOf(requestId + "-HTGD_MES_SpeedFixAction info:" + ret[0] + "-" + ret[1])); if (!"S".equals(ret[0])) { BillFieldUtil util = new BillFieldUtil(); - String tablename = util.getTablename(workFlowId); +// String tablename = util.getTablename(workFlowId); + String tablename = requestinfo.getRequestManager().getBillTableName(); RecordSet rs = I18nContextUtil.getBean(RecordSet.class); String poolname = CONN_TYPE.workflow.getType(); // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/HTGD_MES_TDLApproveActivon.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/HTGD_MES_TDLApproveActivon.java index a757b0d..7637bbc 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/HTGD_MES_TDLApproveActivon.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/HTGD_MES_TDLApproveActivon.java @@ -85,7 +85,8 @@ public class HTGD_MES_TDLApproveActivon extends BaseBean implements Action, EsbS String[] ret = service.returnRes(req); logger_674a8052.info(String.valueOf(requestId + "-HTGD_MES_TDLApproveActivon info:" + ret[0] + "-" + ret[1])); BillFieldUtil util = new BillFieldUtil(); - String tablename = util.getTablename(workFlowId); +// String tablename = util.getTablename(workFlowId); + String tablename = requestinfo.getRequestManager().getBillTableName(); RecordSet rs = I18nContextUtil.getBean(RecordSet.class); String poolname = CONN_TYPE.workflow.getType(); // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/HTWLJiaBanAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/HTWLJiaBanAction.java index c0549e9..a0dbd05 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/HTWLJiaBanAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/HTWLJiaBanAction.java @@ -42,7 +42,8 @@ public class HTWLJiaBanAction extends BaseBean implements Action, EsbServerlessR logger_983b20e3.info(String.valueOf("HTWLJiaBanAction--start--" + requestid)); String wfid = request.getWorkflowid(); BillFieldUtil util = new BillFieldUtil(); - String tablename = util.getTablename(wfid); +// String tablename = util.getTablename(wfid); + String tablename = request.getRequestManager().getBillTableName(); Property[] aproperty = request.getMainTableInfo().getProperty(); String jbrq = ""; String jbrqx = ""; @@ -90,28 +91,29 @@ public class HTWLJiaBanAction extends BaseBean implements Action, EsbServerlessR // 下午打卡记录 String xwdkjl = ""; // TODO 有参构造 :new RecordSetDataSource("onecard") 实例化方式改变,请检查是否有对应有参实现 - RecordSetDataSource rsds = I18nContextUtil.getBean(RecordSetDataSource.class).setPoolname("onecard"); +// RecordSetDataSource rsds = I18nContextUtil.getBean(RecordSetDataSource.class).setPoolname("onecard"); + RecordSet rsds = I18nContextUtil.getBean(RecordSet.class); if ("0".equals(mGZSD)) { // 白班，根据实际加班开始日期 获取当天最早打卡和最晚打卡 String sql = "SELECt (SELECT min(AttendanceDateTime) FROM `view_attendance` where AttendanceDate='" + mSJJB_ksrq_X + "' and UserNo='" + gh + "') as time1, " + " (SELECT max(AttendanceDateTime) FROM `view_attendance` where AttendanceDate='" + mSJJB_ksrq_X + "' and UserNo='" + gh + "') as time2"; logger_983b20e3.info(String.valueOf("查询打卡记录sql:" + sql)); String poolname_y6 = ""; // TODO E10必须指定poolname数据源 - rsds.executeSql(sql, poolname_y6); + rsds.executeSql(sql, "onecard"); } else if ("1".equals(mGZSD)) { // 晚班，根据实际开始日期的最晚打卡时间，根据实际结束日期的最早打卡时间 String sql = "SELECt (SELECT max(AttendanceDateTime) FROM `view_attendance` where AttendanceDate='" + mSJJB_ksrq_X + "' and UserNo='" + gh + "') as time1, " + " (SELECT min(AttendanceDateTime) FROM `view_attendance` where AttendanceDate='" + mSJJB_jsrq_x + "' and UserNo='" + gh + "') as time2"; logger_983b20e3.info(String.valueOf("查询打卡记录sql:" + sql)); String poolname_g7 = ""; // TODO E10必须指定poolname数据源 - rsds.executeSql(sql, poolname_g7); + rsds.executeSql(sql, "onecard"); } else { // RecordSetDataSource rsds = new RecordSetDataSource("onecard"); String sql = "SELECt (SELECT min(AttendanceDateTime) FROM `view_attendance` where AttendanceDate='" + jbrqx + "' and UserNo='" + gh + "' and AttendanceDateTime<'" + jbrq + " 12:00:00" + "') as time1, " + " (SELECT max(AttendanceDateTime) FROM `view_attendance` where AttendanceDate='" + jbrqx + "' and UserNo='" + gh + "' and AttendanceDateTime>'" + jbrq + " 12:00:00" + "') as time2"; logger_983b20e3.info(String.valueOf("查询打卡记录sql:" + sql)); String poolname = ""; // TODO E10必须指定poolname数据源 - rsds.executeSql(sql, poolname); + rsds.executeSql(sql, "onecard"); // String swdkjl = "";//上午打卡记录 // String xwdkjl = "";//下午打卡记录 // while (rsds.next()) { diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/Iur_syncProject.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/Iur_syncProject.java index 8837641..ff0879f 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/Iur_syncProject.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/Iur_syncProject.java @@ -43,7 +43,8 @@ public class Iur_syncProject extends BaseBean implements Action, EsbServerlessRp String workflowid = requestinfo.getWorkflowid(); RecordSet rs = I18nContextUtil.getBean(RecordSet.class); BillFieldUtil util = new BillFieldUtil(); - String tablename = util.getTablename(workflowid); +// String tablename = util.getTablename(workflowid); + String tablename = requestinfo.getRequestManager().getBillTableName(); try { logger_72949ae6.info(String.valueOf("Iur_syncProject--start:" + requestid)); JSONObject map = new JSONObject(); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/OaCrmZDYWFPAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/OaCrmZDYWFPAction.java index 155a6b3..1452c6e 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/OaCrmZDYWFPAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/OaCrmZDYWFPAction.java @@ -56,7 +56,8 @@ public class OaCrmZDYWFPAction extends BaseBean implements Action, EsbServerless requestID = requestInfo.getRequestid(); workflowID = requestInfo.getWorkflowid(); BillFieldUtil util = new BillFieldUtil(); - tablename = util.getTablename(workflowID); +// tablename = util.getTablename(workflowID); + tablename = requestInfo.getRequestManager().getBillTableName(); Map mMap = new HashMap(); for (int i = 0; i < properties.length; i++) { String name = properties[i].getName().toUpperCase(); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/OperateAccountAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/OperateAccountAction.java index fb0cc0d..9aca9d0 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/OperateAccountAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/OperateAccountAction.java @@ -45,7 +45,8 @@ public class OperateAccountAction extends BaseBean implements Action, EsbServerl String requestId = request.getRequestid(); String wfid = request.getWorkflowid(); BillFieldUtil util = new BillFieldUtil(); - String tablename = util.getTablename(wfid); +// String tablename = util.getTablename(wfid); + String tablename = request.getRequestManager().getBillTableName(); RecordSet rs = I18nContextUtil.getBean(RecordSet.class); String stat = ""; String message = ""; diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/OperateMesAccountAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/OperateMesAccountAction.java index e0ba8e0..375c631 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/OperateMesAccountAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/OperateMesAccountAction.java @@ -49,7 +49,8 @@ public class OperateMesAccountAction extends BaseBean implements Action, EsbServ String requestId = request.getRequestid(); String wfid = request.getWorkflowid(); BillFieldUtil util = new BillFieldUtil(); - String tablename = util.getTablename(wfid); +// String tablename = util.getTablename(wfid); + String tablename = request.getRequestManager().getBillTableName(); RecordSet rs = I18nContextUtil.getBean(RecordSet.class); String stat = ""; String message = ""; diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/PushMeetingAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/PushMeetingAction.java index cd77c7f..d03bf4b 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/PushMeetingAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/PushMeetingAction.java @@ -13,12 +13,11 @@ import java.util.concurrent.Executors; import org.apache.commons.lang.StringUtils; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; -import com.weaver.seconddev.interfaces.eipoa.PortalPlanService; -import com.weaver.seconddev.interfaces.eipoa.SI_HTPortalPlan_OUTServiceStub.InsertPlan; -import com.weaver.seconddev.interfaces.swfa.BillFieldUtil; -//TODO config -//import com.weaver.seconddev.interfaces.workflow.entity.Meeting; -//import weaver.wxinterface.InterfaceUtil; +//import weaver.interfaces.eipoa.PortalPlanService; +//import weaver.interfaces.eipoa.SI_HTPortalPlan_OUTServiceStub.InsertPlan; +//import weaver.interfaces.swfa.BillFieldUtil; +//import weaver.interfaces.workflow.entity.Meeting; +//import weaver.meeting.Maint.MeetingRoomComInfo; import java.lang.*; import java.util.*; import com.weaver.verupgrade.workflow.request.RequestManager; @@ -33,6 +32,7 @@ import com.weaver.verupgrade.general.BaseBean; import com.weaver.verupgrade.general.Util; import com.weaver.verupgrade.interfaces.workflow.action.Action; +// import weaver.wxinterface.InterfaceUtil; @org.springframework.stereotype.Service("workflow_action_PushMeetingAction") public class PushMeetingAction extends BaseBean implements Action, EsbServerlessRpcRemoteInterface { @@ -44,15 +44,15 @@ public class PushMeetingAction extends BaseBean implements Action, EsbServerless String[] arr = ids.split(","); Set list = new HashSet(); for(int i=0;i 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_ym,generate); + boolean b = rs.executeSql(sql, poolname_ym, generate); + logger_f5224b91.info("b -----"+ b); if (applyEmpNum.length() < 10) { // 经办人工号 applyEmpNum = errandEmpNum; @@ -607,7 +616,8 @@ public class ZOA_SL_GWCC_Action extends BaseBean implements Action, EsbServerles logger_f5224b91.info(String.valueOf("logsql:" + logsql)); String poolname_6c = CONN_TYPE.workflow.getType(); // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - rs1.executeSql(logsql, poolname_6c); + boolean b1 = rs1.executeSql(logsql, poolname_6c); + logger_f5224b91.info(String.valueOf("b1:" + b1)); } } catch (Exception e) { logger_f5224b91.info(String.valueOf(reid + "商旅接口Exception:" + e.getMessage())); @@ -631,7 +641,8 @@ public class ZOA_SL_GWCC_Action extends BaseBean implements Action, EsbServerles logger_f5224b91.info(String.valueOf("logsql2:" + logsql2)); String poolname_t9 = CONN_TYPE.workflow.getType(); // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - rs1.executeSql(logsql2, poolname_t9); + boolean b1 = rs1.executeSql(logsql2, poolname_t9); + logger_f5224b91.info(String.valueOf("b1:" + b1)); } } catch (Exception e) { logger_f5224b91.info(String.valueOf(reid + "携程接口Exception:" + e.getMessage())); @@ -707,7 +718,8 @@ public class ZOA_SL_GWCC_Action extends BaseBean implements Action, EsbServerles logger_f5224b91.info(String.valueOf("logsql4:" + logsql4)); String poolname_ot = CONN_TYPE.workflow.getType(); // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - rs1.executeSql(logsql4, poolname_ot); + boolean b1= rs1.executeSql(logsql4, poolname_ot); + logger_f5224b91.info(String.valueOf("b4:" + b1)); } catch (Exception e) { e.printStackTrace(); logger_f5224b91.info(String.valueOf(reid + "同程商旅接口Exception:" + e.getMessage())); @@ -759,20 +771,24 @@ public class ZOA_SL_GWCC_Action extends BaseBean implements Action, EsbServerles sta = result[0]; message = result[1]; String sql_log = "insert into sync_eas_log(requestId,lcbh,kssj,jssj,sqrq,ccmdd,gh,name,sxrgh,sxrxm,reason,title,sqbm,sqdw,status,message) " + "values('" + reid + "','" + sourceKey + "','" + kssj + "','" + jssj + "','" + sqrq + "','" + attribute8 + "','" + applyEmpNum + "','" + applyerName + "','" + synergeticNumbers + "'" + ",'" + synergeticNames + "','" + reason + "','" + title + "','" + attribute4 + "','" + attribute5 + "','" + sta + "','" + message + "')"; + logger_f5224b91.info(String.valueOf( "sql_log===" + sql_log)); String poolname_05 = CONN_TYPE.workflow.getType(); /* *TODO 检测到insert语句 -> E9插入sql迁移到E10需要特殊处理请参考文档进行调整 https://www.e-cology.com.cn/sp/doc/docShare/1027709301045985331?tenantKey=t7akvdnf84 TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源*/ generate = IdGenerator.generate(); - rs1.executeSql(sql_log, poolname_05,generate); + boolean b1 = rs1.executeSql(sql_log, poolname_05, generate); + logger_f5224b91.info(String.valueOf( "b1===" + b1)); logger_f5224b91.info(String.valueOf(reid + "同步数据到EAS完成")); } catch (Exception e) { message = e.getMessage(); String sql_log = "insert into sync_eas_log(requestId,lcbh,kssj,jssj,sqrq,ccmdd,gh,name,sxrgh,sxrxm,reason,title,sqbm,sqdw,status,message) " + "values('" + reid + "','" + sourceKey + "','" + kssj + "','" + jssj + "','" + sqrq + "','" + attribute8 + "','" + applyEmpNum + "','" + applyerName + "','" + synergeticNumbers + "'" + ",'" + synergeticNames + "','" + reason + "','" + title + "','" + attribute4 + "','" + attribute5 + "','" + sta + "','" + message + "')"; + logger_f5224b91.info(String.valueOf( "sql_log===" + sql_log)); String poolname_ni = CONN_TYPE.workflow.getType(); /* *TODO 检测到insert语句 -> E9插入sql迁移到E10需要特殊处理请参考文档进行调整 https://www.e-cology.com.cn/sp/doc/docShare/1027709301045985331?tenantKey=t7akvdnf84 TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源*/ generate = IdGenerator.generate(); - rs1.executeSql(sql_log, poolname_ni,generate); + boolean b1 = rs1.executeSql(sql_log, poolname_ni, generate); + logger_f5224b91.info(String.valueOf( "b1===" + b1)); logger_f5224b91.info(String.valueOf(reid + "同步数据到EAS异常:" + e.toString())); } } catch (Exception e) { diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_STATUS_RFCAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_STATUS_RFCAction.java index e9c9175..3489d35 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_STATUS_RFCAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_STATUS_RFCAction.java @@ -47,6 +47,11 @@ public class ZOA_STATUS_RFCAction extends BaseBean implements Action, EsbServerl 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); + + + logger_2bfe536a.info("----- workflow_action_ZOA_STATUS_RFCAction new -----"); + logger_2bfe536a.info("requestIdTemp -----"+ requestIdTemp); + logger_2bfe536a.info("userIdTemp -----"+ userIdTemp); try { BillFieldUtil unit = new BillFieldUtil(); String wfid = requestinfo.getWorkflowid(); @@ -81,9 +86,11 @@ public class ZOA_STATUS_RFCAction extends BaseBean implements Action, EsbServerl logger_2bfe536a.info(String.valueOf("调用ZOA_STATUS_RFC函数成功：" + retstr[0] + "," + retstr[1])); } String sql = "update " + tablename + " set status= '" + retstr[0] + "',message= cast(message as varchar(8000)) +'," + retstr[1] + "' where requestId =" + requestid; + logger_2bfe536a.info("sql -----"+ sql); String poolname_vx = CONN_TYPE.workflow.getType(); // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - rs.executeSql(sql, poolname_vx); + boolean b = rs.executeSql(sql, poolname_vx); + logger_2bfe536a.info("b -----"+ b); if (!"S".equals(retstr[0])) { requestinfo.getRequestManager().setMessageid("ERROR"); requestinfo.getRequestManager().setMessagecontent("SAP返回错误信息：" + retstr[1]); @@ -94,9 +101,11 @@ public class ZOA_STATUS_RFCAction extends BaseBean implements Action, EsbServerl requestinfo.getRequestManager().setMessageid("ERROR"); requestinfo.getRequestManager().setMessagecontent("调用SAP接口出错：" + e.getMessage()); String sql = "update " + tablename + " set status= '" + retstr[0] + "',message= cast(message as varchar(8000)) +'," + retstr[1] + "' where requestId =" + requestid; + logger_2bfe536a.info("sql2 -----"+ sql); String poolname = CONN_TYPE.workflow.getType(); // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - rs.executeSql(sql, poolname); + boolean b = rs.executeSql(sql, poolname); + logger_2bfe536a.info("b2 -----"+ b); return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager())); } return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager())); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOEM_MATRIAL_PRICE.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOEM_MATRIAL_PRICE.java index fa59132..e8af38b 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOEM_MATRIAL_PRICE.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOEM_MATRIAL_PRICE.java @@ -25,6 +25,8 @@ public class ZOEM_MATRIAL_PRICE { } public String[] Getexecute(String[][] as) { + + logger_8118cdc9.info("ZOEM_MATRIAL_PRICE - Getexecute as = " + as.toString()); retstr = new String[2]; try { JCoFunction jcofunction = destination.getRepository().getFunction("ZOEM_MATRIAL_PRICE"); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOEM_MATRIAL_PRICE_Action.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOEM_MATRIAL_PRICE_Action.java index fcaf91d..40bd2c3 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOEM_MATRIAL_PRICE_Action.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOEM_MATRIAL_PRICE_Action.java @@ -40,6 +40,10 @@ public class ZOEM_MATRIAL_PRICE_Action extends BaseBean implements Action, EsbSe 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); + + logger_8aa7358c.info("----- workflow_action_ZOEM_MATRIAL_PRICE_Action new -----"); + logger_8aa7358c.info("requestIdTemp -----"+ requestIdTemp); + logger_8aa7358c.info("userIdTemp -----"+ userIdTemp); try { String requestid = requestinfo.getRequestid(); String wfid = requestinfo.getWorkflowid(); @@ -95,11 +99,15 @@ public class ZOEM_MATRIAL_PRICE_Action extends BaseBean implements Action, EsbSe } RecordSet rs = I18nContextUtil.getBean(RecordSet.class); BillFieldUtil util = new BillFieldUtil(); - String tablename = util.getTablename(wfid); +// String tablename = util.getTablename(wfid); + String tablename = requestinfo.getRequestManager().getBillTableName(); String sql = "update " + tablename + " set state='" + state + "',message='" + sb.toString() + "' where requestid=" + requestid; + + logger_8aa7358c.info("sql -----"+ sql); String poolname = CONN_TYPE.workflow.getType(); // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - rs.executeSql(sql, poolname); + boolean b = rs.executeSql(sql, poolname); + logger_8aa7358c.info("b -----"+ b); } catch (Exception e) { logger_8aa7358c.info(String.valueOf("ZOEM_PRICE_DIFFERENCE_RATE_Action-error-" + requestid + "-[" + e.toString() + "]")); requestinfo.getRequestManager().setMessagecontent("调用SAP接口同步数据出错：" + e.toString()); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOEM_PRICE_DIFFERENCE_RATE.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOEM_PRICE_DIFFERENCE_RATE.java index bfeecc8..158585a 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOEM_PRICE_DIFFERENCE_RATE.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOEM_PRICE_DIFFERENCE_RATE.java @@ -29,6 +29,8 @@ public class ZOEM_PRICE_DIFFERENCE_RATE { } public String[] Getexecute(String[][] as, String[][] as2) { + + logger_8a2de3c9.info(String.valueOf("ZOEM_PRICE_DIFFERENCE_RATE- Getexecute --" + as.toString())); retstr = new String[2]; try { JCoFunction jcofunction = destination.getRepository().getFunction("ZOEM_PRICE_DIFFERENCE_RATE"); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOEM_PRICE_DIFFERENCE_RATE_Action.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOEM_PRICE_DIFFERENCE_RATE_Action.java index d522f32..6c25ee7 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOEM_PRICE_DIFFERENCE_RATE_Action.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOEM_PRICE_DIFFERENCE_RATE_Action.java @@ -41,6 +41,10 @@ public class ZOEM_PRICE_DIFFERENCE_RATE_Action extends BaseBean implements Actio 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); + + logger_69cd5f8c.info("----- workflow_action_ZOEM_PRICE_DIFFERENCE_RATE_Action new -----"); + logger_69cd5f8c.info("requestIdTemp -----"+ requestIdTemp); + logger_69cd5f8c.info("userIdTemp -----"+ userIdTemp); try { String requestid = requestinfo.getRequestid(); String wfid = requestinfo.getWorkflowid(); @@ -150,11 +154,15 @@ public class ZOEM_PRICE_DIFFERENCE_RATE_Action extends BaseBean implements Actio sb.append("OEM成品差价率返回结果：" + ret[1]); RecordSet rs = I18nContextUtil.getBean(RecordSet.class); BillFieldUtil util = new BillFieldUtil(); - String tablename = util.getTablename(wfid); +// String tablename = util.getTablename(wfid); + String tablename = requestinfo.getRequestManager().getBillTableName(); String sql = "update " + tablename + " set state='" + state + "',message='" + sb.toString() + "' where requestid=" + requestid; + logger_69cd5f8c.info("sql -----"+ sql); String poolname = CONN_TYPE.workflow.getType(); // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - rs.executeSql(sql, poolname); + boolean b = rs.executeSql(sql, poolname); + logger_69cd5f8c.info("b -----"+ b); + } catch (Exception e) { logger_69cd5f8c.info(String.valueOf("ZOEM_PRICE_DIFFERENCE_RATE_Action-error-" + requestid + "-[" + e.toString() + "]")); requestinfo.getRequestManager().setMessagecontent("OEM成品差价率返回结果：" + e.toString()); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOEM_PROCESSING_CHARGE_Action.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOEM_PROCESSING_CHARGE_Action.java index 518380a..fc0d142 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOEM_PROCESSING_CHARGE_Action.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOEM_PROCESSING_CHARGE_Action.java @@ -40,6 +40,11 @@ public class ZOEM_PROCESSING_CHARGE_Action extends BaseBean implements Action, E 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); + + logger_9b3f3cb8.info("----- workflow_action_ZOEM_PROCESSING_CHARGE_Action new -----"); + logger_9b3f3cb8.info("requestIdTemp -----"+ requestIdTemp); + logger_9b3f3cb8.info("userIdTemp -----"+ userIdTemp); + try { String requestid = requestinfo.getRequestid(); String wfid = requestinfo.getWorkflowid(); @@ -93,11 +98,15 @@ public class ZOEM_PROCESSING_CHARGE_Action extends BaseBean implements Action, E } RecordSet rs = I18nContextUtil.getBean(RecordSet.class); BillFieldUtil util = new BillFieldUtil(); - String tablename = util.getTablename(wfid); +// String tablename = util.getTablename(wfid); + String tablename = requestinfo.getRequestManager().getBillTableName(); String sql = "update " + tablename + " set state='" + state + "',message='" + sb.toString() + "' where requestid=" + requestid; + + logger_9b3f3cb8.info("sql -----"+ sql); String poolname = CONN_TYPE.workflow.getType(); // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - rs.executeSql(sql, poolname); + boolean b = rs.executeSql(sql, poolname); + logger_9b3f3cb8.info("b -----"+ b); } catch (Exception e) { logger_9b3f3cb8.info(String.valueOf("ZOEM_PROCESSING_CHARGE_Action-error-" + requestid + "-[" + e.toString() + "]")); requestinfo.getRequestManager().setMessagecontent("调用SAP接口同步数据出错：" + e.toString()); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZSRM_PUR_INFO.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZSRM_PUR_INFO.java index 41a3769..132609e 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZSRM_PUR_INFO.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZSRM_PUR_INFO.java @@ -25,6 +25,8 @@ public class ZSRM_PUR_INFO { } public String[] Getexecute(String[][] as) { + + logger_741408ac.info("ZSRM_PUR_INFO Getexecute as = " + as); retstr = new String[2]; try { JCoFunction jcofunction = destination.getRepository().getFunction("ZSRM_PUR_INFO"); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZSRM_PUR_INFO_Action.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZSRM_PUR_INFO_Action.java index 6df23b3..b4753ed 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZSRM_PUR_INFO_Action.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZSRM_PUR_INFO_Action.java @@ -38,6 +38,12 @@ public class ZSRM_PUR_INFO_Action extends BaseBean implements Action, EsbServerl 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); + + logger_78218549.info("----- workflow_action_ZSRM_PUR_INFO_Action new -----"); + logger_78218549.info("requestIdTemp -----"+ requestIdTemp); + logger_78218549.info("userIdTemp -----"+ userIdTemp); + + try { String requestid = requestinfo.getRequestid(); String wfid = requestinfo.getWorkflowid(); @@ -134,11 +140,14 @@ public class ZSRM_PUR_INFO_Action extends BaseBean implements Action, EsbServerl } RecordSet rs = I18nContextUtil.getBean(RecordSet.class); BillFieldUtil util = new BillFieldUtil(); - String tablename = util.getTablename(wfid); +// String tablename = util.getTablename(wfid); + String tablename = requestinfo.getRequestManager().getBillTableName(); String sql = "update " + tablename + " set state='" + state + "',message='" + sb.toString() + "' where requestid=" + requestid; + logger_78218549.info("sql -----"+ sql); String poolname = CONN_TYPE.workflow.getType(); // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - rs.executeSql(sql, poolname); + boolean b = rs.executeSql(sql, poolname); + logger_78218549.info("b -----"+ b); } catch (Exception e) { logger_78218549.info(String.valueOf("ZSRM_PUR_INFO_Action-error-" + requestid + "-[" + e.toString() + "]")); requestinfo.getRequestManager().setMessagecontent("调用SAP接口同步数据出错：" + e.toString()); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZSRM_PUR_INFO_CheckAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZSRM_PUR_INFO_CheckAction.java index f4d69b5..5fa7f09 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZSRM_PUR_INFO_CheckAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZSRM_PUR_INFO_CheckAction.java @@ -37,6 +37,10 @@ public class ZSRM_PUR_INFO_CheckAction extends BaseBean implements Action, EsbSe 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); + + logger_9ad0d62b.info("----- workflow_action_ZSRM_PUR_INFO_CheckAction new -----"); + logger_9ad0d62b.info("requestIdTemp -----"+ requestIdTemp); + logger_9ad0d62b.info("userIdTemp -----"+ userIdTemp); try { String requestid = requestinfo.getRequestid(); try { diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZSRM_PUR_INFO_GY107_Action.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZSRM_PUR_INFO_GY107_Action.java index 6de3e3c..09ee8d2 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZSRM_PUR_INFO_GY107_Action.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZSRM_PUR_INFO_GY107_Action.java @@ -38,12 +38,17 @@ public class ZSRM_PUR_INFO_GY107_Action extends BaseBean implements Action, EsbS 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); + + logger_da6b5da2.info("----- workflow_action_ZSRM_PUR_INFO_GY107_Action new -----"); + logger_da6b5da2.info("requestIdTemp -----"+ requestIdTemp); + logger_da6b5da2.info("userIdTemp -----"+ userIdTemp); try { String requestid = requestinfo.getRequestid(); String wfid = requestinfo.getWorkflowid(); RecordSet rs = I18nContextUtil.getBean(RecordSet.class); BillFieldUtil util = new BillFieldUtil(); - String tablename = util.getTablename(wfid); +// String tablename = util.getTablename(wfid); + String tablename = requestinfo.getRequestManager().getBillTableName(); try { logger_da6b5da2.info(String.valueOf("ZSRM_PUR_INFO_GY107_Action-start-" + requestid)); String sync = ""; @@ -96,20 +101,25 @@ public class ZSRM_PUR_INFO_GY107_Action extends BaseBean implements Action, EsbS ZSRM_PUR_INFO info = new ZSRM_PUR_INFO(); String[] ret = info.Getexecute(str); logger_da6b5da2.info(String.valueOf("ZSRM_PUR_INFO_GY107_Action-return-" + requestid + "-[" + ret[0] + "," + ret[1] + "]")); - String sql = "update " + tablename + " set state='" + ret[0] + "',message='" + ret[1] + "' where requestid=" + requestid; + String sql = "update e10_core_business." + tablename + " set state='" + ret[0] + "',message='" + ret[1] + "' where requestid=" + requestid; + + logger_da6b5da2.info("sql -----"+ sql); String poolname_mm = CONN_TYPE.workflow.getType(); // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - rs.executeSql(sql, poolname_mm); + boolean b = rs.executeSql(sql, poolname_mm); + logger_da6b5da2.info("b -----"+ b); } } } catch (Exception e) { logger_da6b5da2.info(String.valueOf("ZSRM_PUR_INFO_GY107_Action-error-" + requestid + "-[" + e.toString() + "]")); requestinfo.getRequestManager().setMessageid("ERROR"); requestinfo.getRequestManager().setMessagecontent("调用SAP接口校验数据出错：" + e.toString()); - String sql = "update " + tablename + " set state='E',message='" + e.toString() + "' where requestid=" + requestid; + String sql = "update e10_core_business." + tablename + " set state='E',message='" + e.toString() + "' where requestid=" + requestid; + logger_da6b5da2.info("sql2 -----"+ sql); String poolname = CONN_TYPE.workflow.getType(); // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - rs.executeSql(sql, poolname); + boolean b = rs.executeSql(sql, poolname); + logger_da6b5da2.info("b2 -----"+ b); } logger_da6b5da2.info(String.valueOf("ZSRM_PUR_INFO_GY107_Action-end-" + requestid)); return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager())); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZSRM_PUR_INFO_GY107_CheckAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZSRM_PUR_INFO_GY107_CheckAction.java index 7bb4c38..82249de 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZSRM_PUR_INFO_GY107_CheckAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZSRM_PUR_INFO_GY107_CheckAction.java @@ -34,6 +34,11 @@ public class ZSRM_PUR_INFO_GY107_CheckAction extends BaseBean implements Action, 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); + + logger_6ccd4d72.info("----- workflow_action_ZSRM_PUR_INFO_GY107_CheckAction new -----"); + logger_6ccd4d72.info("requestIdTemp -----"+ requestIdTemp); + logger_6ccd4d72.info("userIdTemp -----"+ userIdTemp); + try { String requestid = requestinfo.getRequestid(); try { diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZSRM_PUR_INFO_GY132_Action.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZSRM_PUR_INFO_GY132_Action.java index fe15456..578efca 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZSRM_PUR_INFO_GY132_Action.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZSRM_PUR_INFO_GY132_Action.java @@ -38,12 +38,18 @@ public class ZSRM_PUR_INFO_GY132_Action extends BaseBean implements Action, EsbS 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); + + + logger_8fd2ca4a.info("----- workflow_action_ZSRM_PUR_INFO_GY132_Action new -----"); + logger_8fd2ca4a.info("requestIdTemp -----"+ requestIdTemp); + logger_8fd2ca4a.info("userIdTemp -----"+ userIdTemp); try { String requestid = requestinfo.getRequestid(); String wfid = requestinfo.getWorkflowid(); RecordSet rs = I18nContextUtil.getBean(RecordSet.class); BillFieldUtil util = new BillFieldUtil(); - String tablename = util.getTablename(wfid); +// String tablename = util.getTablename(wfid); + String tablename = requestinfo.getRequestManager().getBillTableName(); try { logger_8fd2ca4a.info(String.valueOf("ZSRM_PUR_INFO_GY132_Action-start-" + requestid)); String sync = ""; @@ -96,20 +102,24 @@ public class ZSRM_PUR_INFO_GY132_Action extends BaseBean implements Action, EsbS ZSRM_PUR_INFO info = new ZSRM_PUR_INFO(); String[] ret = info.Getexecute(str); logger_8fd2ca4a.info(String.valueOf("ZSRM_PUR_INFO_GY132_Action-return-" + requestid + "-[" + ret[0] + "," + ret[1] + "]")); - String sql = "update " + tablename + " set state='" + ret[0] + "',message='" + ret[1] + "' where requestid=" + requestid; + String sql = "update e10_core_business." + tablename + " set state='" + ret[0] + "',message='" + ret[1] + "' where requestid=" + requestid; + logger_8fd2ca4a.info("sql -----"+ sql); String poolname_r3 = CONN_TYPE.workflow.getType(); // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - rs.executeSql(sql, poolname_r3); + boolean b = rs.executeSql(sql, poolname_r3); + logger_8fd2ca4a.info("b -----"+ b); } } } catch (Exception e) { logger_8fd2ca4a.info(String.valueOf("ZSRM_PUR_INFO_GY132_Action-error-" + requestid + "-[" + e.toString() + "]")); requestinfo.getRequestManager().setMessageid("ERROR"); requestinfo.getRequestManager().setMessagecontent("调用SAP接口校验数据出错：" + e.toString()); - String sql = "update " + tablename + " set state='E',message='" + e.toString() + "' where requestid=" + requestid; + String sql = "update e10_core_business." + tablename + " set state='E',message='" + e.toString() + "' where requestid=" + requestid; + logger_8fd2ca4a.info("sql2 -----"+ sql); String poolname = CONN_TYPE.workflow.getType(); // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - rs.executeSql(sql, poolname); + boolean b = rs.executeSql(sql, poolname); + logger_8fd2ca4a.info("b2 -----"+ b); } logger_8fd2ca4a.info(String.valueOf("ZSRM_PUR_INFO_GY132_Action-end-" + requestid)); return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager())); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZSRM_PUR_INFO_GY132_CheckAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZSRM_PUR_INFO_GY132_CheckAction.java index 5bab2fb..b46caa4 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZSRM_PUR_INFO_GY132_CheckAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZSRM_PUR_INFO_GY132_CheckAction.java @@ -34,6 +34,11 @@ public class ZSRM_PUR_INFO_GY132_CheckAction extends BaseBean implements Action, 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); + + + logger_69d789ca.info("----- workflow_action_ZSRM_PUR_INFO_GY132_CheckAction new -----"); + logger_69d789ca.info("requestIdTemp -----"+ requestIdTemp); + logger_69d789ca.info("userIdTemp -----"+ userIdTemp); try { String requestid = requestinfo.getRequestid(); try { @@ -47,6 +52,7 @@ public class ZSRM_PUR_INFO_GY132_CheckAction extends BaseBean implements Action, sync = value; } } + logger_69d789ca.info("sync -----"+ sync); if ("0".equals(sync)) { DetailTable[] detailtable = requestinfo.getDetailTableInfo().getDetailTable(); DetailTable dtq = detailtable[1]; diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZSR_PUR_INFO_OEM_Action.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZSR_PUR_INFO_OEM_Action.java index 8dca7f9..44cf42e 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZSR_PUR_INFO_OEM_Action.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZSR_PUR_INFO_OEM_Action.java @@ -43,6 +43,10 @@ public class ZSR_PUR_INFO_OEM_Action extends BaseBean implements Action, EsbServ 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); + + logger_adc1e038.info("----- workflow_action_ZSR_PUR_INFO_OEM_Action new -----"); + logger_adc1e038.info("requestIdTemp -----"+ requestIdTemp); + logger_adc1e038.info("userIdTemp -----"+ userIdTemp); try { String requestid = requestinfo.getRequestid(); String wfid = requestinfo.getWorkflowid(); @@ -63,11 +67,13 @@ public class ZSR_PUR_INFO_OEM_Action extends BaseBean implements Action, EsbServ String state = ""; int mxcount = 0; String sql = "select count(b.id) as mxcount from " + tablename + " a," + tablename + "_dt1 b where a.id = b.mainid and a.requestId =" + requestid + " and isnull(sfbjsc,1)<>0"; + logger_adc1e038.info("sql -----"+ sql); String poolname = CONN_TYPE.workflow.getType(); // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 rs.executeSql(sql, poolname); if (rs.next()) { mxcount = rs.getInt("mxcount"); + logger_adc1e038.info("mxcount -----"+ mxcount); } if (mxcount > 0) { int j = 0; @@ -138,9 +144,11 @@ public class ZSR_PUR_INFO_OEM_Action extends BaseBean implements Action, EsbServ } BillFieldUtil util = new BillFieldUtil(); sql = "update " + tablename + " set state='" + state + "',message='" + sb.toString() + "' where requestid=" + requestid; + logger_adc1e038.info("update sql -----"+ sql); String poolname_d9 = CONN_TYPE.workflow.getType(); // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - rs.executeSql(sql, poolname_d9); + boolean b = rs.executeSql(sql, poolname_d9); + logger_adc1e038.info("b -----"+ b); } catch (Exception e) { logger_adc1e038.info(String.valueOf("ZSR_PUR_INFO_OEM_Action-error-" + requestid + "-[" + e.toString() + "]")); requestinfo.getRequestManager().setMessagecontent("调用SAP接口同步数据出错：" + e.toString()); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZWZX_CG_FileUploadAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZWZX_CG_FileUploadAction.java index b766e19..def9619 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZWZX_CG_FileUploadAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZWZX_CG_FileUploadAction.java @@ -52,6 +52,10 @@ public class ZWZX_CG_FileUploadAction 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); + + logger_323752e9.info("----- workflow_action_ZWZX_CG_FileUploadAction new -----"); + logger_323752e9.info("requestIdTemp -----"+ requestIdTemp); + logger_323752e9.info("userIdTemp -----"+ userIdTemp); try { /** * 请求ID* @@ -143,7 +147,7 @@ public class ZWZX_CG_FileUploadAction extends BaseBean implements Action, EsbSer String[] docs = fileIds.split(","); for (int i = 0; i < docs.length; i++) { String docid = docs[i]; - String sql = " select b.filerealpath,b.iszip,b.name,b.imagefileid from " + " fileobj b where b.imagefileid in(select max(imagefileid) " + "from document_main_access as docimagefile where docid in(" + docid + ") group by docid)"; + String sql = " select b.filerealpath,b.iszip,b.name,b.imagefileid from " + " e10_common.dbo.fileobj b where b.imagefileid in(select max(imagefileid) " + "from e10_core_business.dbo.document_main_access as docimagefile where docid in(" + docid + ") group by docid)"; String poolname = CONN_TYPE.workflow.getType(); // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 rs.executeSql(sql, poolname); @@ -167,6 +171,8 @@ public class ZWZX_CG_FileUploadAction extends BaseBean implements Action, EsbSer fileItem.put("fileName", imagefilename); fileItem.put("fileContent", uploadBuffer); fileItem.put("invoiceNo", ""); + + logger_323752e9.info(String.valueOf("fileItem =" + fileItem)); fileVOListArr.add(fileItem); baos.close(); fi.close(); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZZ_DZDAFDApproveAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZZ_DZDAFDApproveAction.java index 6fb5bc5..acc95b1 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZZ_DZDAFDApproveAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZZ_DZDAFDApproveAction.java @@ -46,6 +46,10 @@ public class ZZ_DZDAFDApproveAction extends BaseBean implements Action, EsbServe 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); + + logger_ccc3e432.info("----- workflow_action_ZZ_DZDAFDApproveAction new -----"); + logger_ccc3e432.info("requestIdTemp -----"+ requestIdTemp); + logger_ccc3e432.info("userIdTemp -----"+ userIdTemp); try { /** * 请求ID* @@ -89,6 +93,7 @@ public class ZZ_DZDAFDApproveAction extends BaseBean implements Action, EsbServe // 调用接口 // url = Util.null2String(I18nContextUtilcus.getBean(Environment.class).getProperty("hteasoasync.dzdafd_zz_url")).trim(); url = configProp.getDzdafd_zz_url(); + logger_ccc3e432.info("url" + url); String yoaywbh = mMap.get("YOAYWBH"); mJson.put("receiptNO", yoaywbh); mJson.put("voucherSysFrom", "OA"); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZZ_GDFileUploadAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZZ_GDFileUploadAction.java index 2e07e21..bd22a8e 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZZ_GDFileUploadAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZZ_GDFileUploadAction.java @@ -59,6 +59,10 @@ public class ZZ_GDFileUploadAction extends BaseBean implements Action, EsbServer 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); + + logger_b14cb5d0.info("----- workflow_action_ZZ_GDFileUploadAction new -----"); + logger_b14cb5d0.info("requestIdTemp -----"+ requestIdTemp); + logger_b14cb5d0.info("userIdTemp -----"+ userIdTemp); try { /** * 请求ID* @@ -143,7 +147,8 @@ public class ZZ_GDFileUploadAction extends BaseBean implements Action, EsbServer String[] docs = fileIds.split(","); for (int i = 0; i < docs.length; i++) { String docid = docs[i]; - String sql = " select b.filerealpath,b.iszip,b.name,b.imagefileid from " + " fileobj b where b.imagefileid in(select max(imagefileid) " + "from document_main_access as docimagefile where docid in(" + docid + ") group by docid)"; + String sql = " select b.filerealpath,b.iszip,b.name,b.imagefileid from " + " e10_core_business.dbo.fileobj b where b.imagefileid in(select max(imagefileid) " + "from e10_core_business.dbo.document_main_access as docimagefile where docid in(" + docid + ") group by docid)"; + logger_b14cb5d0.info("sql -----"+ sql); String poolname = CONN_TYPE.workflow.getType(); // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 rs.executeSql(sql, poolname); @@ -167,6 +172,8 @@ public class ZZ_GDFileUploadAction extends BaseBean implements Action, EsbServer fileItem.put("fileName", imagefilename); fileItem.put("fileContent", uploadBuffer); fileItem.put("invoiceNo", ""); + + logger_b14cb5d0.info("fileItem -----"+ fileItem); fileVOListArr.add(fileItem); baos.close(); fi.close(); @@ -289,9 +296,12 @@ public class ZZ_GDFileUploadAction extends BaseBean implements Action, EsbServer RecordSet recordSet = I18nContextUtil.getBean(RecordSet.class); String poolname_48 = CONN_TYPE.workflow.getType(); // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - recordSet.executeSql("select c.name from wfp_base a " + "INNER JOIN form_field b on a.formid=b.form_id " + "INNER JOIN field_option c on b.id=c.field_id " + "where b.fieldname='" + fieldname + "' and a.id=" + workflowid + " and c.selectvalue=" + selectvalue, poolname_48); + String sql = "select c.name from e10_common.dbo.wfp_base a " + "INNER JOIN e10_common.dbo.form_field b on a.formid=b.form_id " + "INNER JOIN e10_common.dbo.field_option c on b.id=c.field_id " + "where b.fieldname='" + fieldname + "' and a.id=" + workflowid + " and c.selectvalue=" + selectvalue; + logger_b14cb5d0.info("getselectNameByCol sql = " + sql ); + recordSet.executeSql(sql, poolname_48); if (recordSet.next()) { name = recordSet.getString("selectname"); + logger_b14cb5d0.info("getselectNameByCol name = " + name ); } return name; } diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZZ_Ten_GDFileUploadAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZZ_Ten_GDFileUploadAction.java index 78644fd..925668a 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZZ_Ten_GDFileUploadAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZZ_Ten_GDFileUploadAction.java @@ -55,6 +55,9 @@ public class ZZ_Ten_GDFileUploadAction extends BaseBean implements Action, EsbSe 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); + logger_8ab26152.info("----- workflow_action_ZZ_Ten_GDFileUploadAction new -----"); + logger_8ab26152.info("requestIdTemp -----"+ requestIdTemp); + logger_8ab26152.info("userIdTemp -----"+ userIdTemp); try { /** * 请求ID* @@ -154,11 +157,13 @@ public class ZZ_Ten_GDFileUploadAction extends BaseBean implements Action, EsbSe String[] docs = fileIds.split(","); for (int i = 0; i < docs.length; i++) { String docid = docs[i]; - String sql = " select b.filerealpath,b.iszip,b.name,b.imagefileid from " + " fileobj b where b.imagefileid in(select max(imagefileid) " + "from document_main_access as docimagefile where docid in(" + docid + ") group by docid)"; + String sql = " select b.filerealpath,b.iszip,b.name,b.imagefileid from " + " e10_core_business.dbo.fileobj b where b.imagefileid in(select max(imagefileid) " + "from document_main_access as docimagefile where docid in(" + docid + ") group by docid)"; + logger_8ab26152.info("sql -----"+ sql); String poolname = CONN_TYPE.workflow.getType(); // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 rs.executeSql(sql, poolname); if (rs.next()) { + JSONObject fileItem = new JSONObject(); String imagefileid = Util.null2String(rs.getString("imagefileid")); String filerealpath = Util.null2String(rs.getString("filerealpath")); @@ -178,6 +183,8 @@ public class ZZ_Ten_GDFileUploadAction extends BaseBean implements Action, EsbSe fileItem.put("fileName", imagefilename); fileItem.put("fileContent", uploadBuffer); fileItem.put("invoiceNo", ""); + + logger_8ab26152.info("fileItem == "+fileItem); fileVOListArr.add(fileItem); baos.close(); fi.close(); @@ -293,10 +300,13 @@ public class ZZ_Ten_GDFileUploadAction extends BaseBean implements Action, EsbSe RecordSet recordSet = I18nContextUtil.getBean(RecordSet.class); String poolname_w2 = CONN_TYPE.workflow.getType(); // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - recordSet.executeSql("select c.name from wfp_base a " + "INNER JOIN form_field b on a.formid=b.form_id " + "INNER JOIN field_option c on b.id=c.field_id " + "where b.fieldname='" + fieldname + "' and a.id=" + workflowid + " and c.selectvalue=" + selectvalue, poolname_w2); + String sql = "select c.name from wfp_base a " + "INNER JOIN e10_common.dbo.form_field b on a.formid=b.form_id " + "INNER JOIN e10_common.dbo.field_option c on b.id=c.field_id " + "where b.fieldname='" + fieldname + "' and a.id=" + workflowid + " and c.selectvalue=" + selectvalue; + logger_8ab26152.info("getselectNameByCol sql = " + sql); + recordSet.executeSql(sql, poolname_w2); if (recordSet.next()) { name = recordSet.getString("selectname"); } + logger_8ab26152.info("getselectNameByCol name = " + name); return name; }