From 4af7983f7f5d92f286e1bbb89299a111492b841e Mon Sep 17 00:00:00 2001 From: yangzt Date: Fri, 28 Feb 2025 14:56:11 +0800 Subject: [PATCH] =?UTF-8?q?yzt-20250226-=E9=97=AE=E9=A2=98=E6=B8=85?= =?UTF-8?q?=E5=8D=95=E5=BA=8F=E5=8F=B7633-=E8=B0=83=E7=94=A8=E6=8E=A5?= =?UTF-8?q?=E5=8F=A3=E6=8A=A5=E9=94=993?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../workflow/action/NewBuKaAction.java | 19 ++++++++++++++----- 1 file changed, 14 insertions(+), 5 deletions(-) diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/NewBuKaAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/NewBuKaAction.java index 41786c6..755181e 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/NewBuKaAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/NewBuKaAction.java @@ -51,7 +51,7 @@ public class NewBuKaAction extends BaseBean implements Action, EsbServerlessRpcR Long userIdTemp = Long.parseLong(String.valueOf(requestInfoMap.getOrDefault("userid", -1))); RequestInfo request = requestInfoTemp.getRequestInfo(requestIdTemp, userIdTemp); try { - String requestid = request.getRequestid(); + String requestid =String.valueOf(requestIdTemp); try { logger_eae3b780.error(String.valueOf("NewBuKaAction--start--" + requestid)); String creater = request.getCreatorid(); @@ -115,11 +115,20 @@ public class NewBuKaAction extends BaseBean implements Action, EsbServerlessRpcR bkyy = valueq; } } - long generate = IdGenerator.generate(); - String insertsql = "insert into buka_log_new(requestid,gh,punchreason,punchtype,TimeCardDate,TimeCardTime,createrId,BKRQ) values(" + requestid + ",'" + GH + "','" + bkyy + "','" + kz + "','" + qksj + "','" + bkrq + " " + bksj + "','" + createrId + "','" + BKRQ + "')"; +// long generate = IdGenerator.generate(); + RecordSet recordSet = I18nContextUtil.getBean(RecordSet.class); String poolname_g0 = CONN_TYPE.workflow.getType(); - logger_eae3b780.error("generate:"+generate+",poolname_g0:"+poolname_g0+",sql1:" + insertsql); - boolean b1 = rs.executeSql(insertsql, poolname_g0,generate); + String newIdSql = "SELECT ISNULL((SELECT TOP 1 id FROM buka_log_new ORDER BY id DESC), 0) + 1 AS id"; + logger_eae3b780.error("newIdSql----------- " + newIdSql); + boolean flag = rs.executeSql(newIdSql, poolname_g0); + logger_eae3b780.error("flag---"+flag); + long newId = 0; + if (recordSet.next()) { + newId = Long.parseLong(recordSet.getString("id")); + } + String insertsql = "insert into buka_log_new(id,requestid,gh,punchreason,punchtype,TimeCardDate,TimeCardTime,createrId,BKRQ) values(" + newId + ",'"+ requestid + ",'" + GH + "','" + bkyy + "','" + kz + "','" + qksj + "','" + bkrq + " " + bksj + "','" + createrId + "','" + BKRQ + "')"; + logger_eae3b780.error("newId:"+newId+",poolname_g0:"+poolname_g0+",sql1:" + insertsql); + boolean b1 = rs.executeSql(insertsql, poolname_g0); logger_eae3b780.error("b1--"+b1); // /* *TODO 检测到insert语句 -> E9插入sql迁移到E10需要特殊处理请参考文档进行调整 https://www.e-cology.com.cn/sp/doc/docShare/1027709301045985331?tenantKey=t7akvdnf84 // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源*/