From d043a18971fddac5f8f1a50d40bd4c7f43fbe990 Mon Sep 17 00:00:00 2001 From: calyrex <2213354201@qq.com> Date: Mon, 16 Dec 2024 14:47:07 +0800 Subject: [PATCH] CloseAccountAction update --- .../workflow/action/CloseAccountAction.java | 13 +++++++++---- 1 file changed, 9 insertions(+), 4 deletions(-) diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/CloseAccountAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/CloseAccountAction.java index 6697c33..4448641 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/CloseAccountAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/CloseAccountAction.java @@ -40,16 +40,18 @@ public class CloseAccountAction extends BaseBean implements Action, EsbServerles } public WeaResult> execute(Map requestInfoMap) { + logger_ac56032a.info("CloseAccountAction start"); Map weaverResultMap = new HashMap<>(); Long requestIdTemp = Long.parseLong(String.valueOf(requestInfoMap.getOrDefault("requestid", -1))); Long userIdTemp = Long.parseLong(String.valueOf(requestInfoMap.getOrDefault("userid", -1))); RequestInfo request = requestInfoTemp.getRequestInfo(requestIdTemp, userIdTemp); - logger_ac56032a.info("CloseAccountAction start"); try { String requestId = request.getRequestid(); String wfid = request.getWorkflowid(); - BillFieldUtil bill = new BillFieldUtil(); - String tablename = bill.getTablename(wfid); +// BillFieldUtil bill = new BillFieldUtil(); +// String tablename = bill.getTablename(wfid); + String tablename = request.getRequestManager().getBillTableName(); + logger_ac56032a.info("tablename--" + tablename); RecordSet rs = I18nContextUtil.getBean(RecordSet.class); String status = ""; String message = ""; @@ -116,6 +118,7 @@ public class CloseAccountAction extends BaseBean implements Action, EsbServerles } } sql_error = "update " + tablename + " set status='" + status + "',message='" + message + "' where requestId=" + requestId; + logger_ac56032a.info("sql_error -- " + sql_error); String poolname_1n = CONN_TYPE.workflow.getType(); // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 rs.executeSql(sql_error, poolname_1n); @@ -126,18 +129,20 @@ public class CloseAccountAction extends BaseBean implements Action, EsbServerles } } catch (Exception e) { sql_error = "update " + tablename + " set status='E',message='" + e.toString() + "' where requestId=" + requestId; + logger_ac56032a.info("sql_error -- " + sql_error); String poolname = CONN_TYPE.workflow.getType(); // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 rs.executeSql(sql_error, poolname); logger_ac56032a.info(String.valueOf(requestId + "批量销户失败：" + e.toString())); request.getRequestManager().setMessageid("ERROR"); request.getRequestManager().setMessagecontent("门户返回错误信息：" + e.toString()); + return WeaResult.fail(500, "出错啦", getResultMapForAction(weaverResultMap, "result", "", request.getRequestManager())); } return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, request.getRequestManager())); } catch (Exception e) { e.printStackTrace(); logger_ac56032a.error("CloseAccountAction e: {}", e.getMessage()); - return WeaResult.success(getResultMapForAction(weaverResultMap, "result", WeaResult.fail(500, "执行异常", getResultMapForAction(weaverResultMap, "result", e.getMessage(), request.getRequestManager())), request.getRequestManager())); + return WeaResult.fail(500, "出错啦", getResultMapForAction(weaverResultMap, "result", "", request.getRequestManager())); } }