From 9406ca688cb39cb94322c91aada04f5b53d02b5d Mon Sep 17 00:00:00 2001 From: qijirenjian Date: Mon, 6 Jan 2025 15:21:39 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9C=AA=E5=90=AF=E7=94=A8=E6=8E=92=E9=99=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../action/ARSPaymentRecepitAction.java | 5 +- .../action/AddVenMatExtsToSrmAction.java | 8 +- .../action/BlackListTempThawCheckAction.java | 6 +- .../workflow/action/BuQianKaAction.java | 5 +- .../workflow/action/ChangeOrgRoleAction.java | 106 ++++++----- .../workflow/action/CloseAccountAction.java | 174 ++++++++--------- .../action/EAS_VoucherModifyAction.java | 179 +++++++++--------- .../action/UpdateSeclevelAndpasswordlock.java | 98 +++++----- .../workflow/action/ZOA_PRICE_RFCAction.java | 91 ++++----- .../workflow/action/ZOA_SIGN_RFCAction.java | 92 ++++----- .../workflow/action/ZOA_SL_GWCC_Action.java | 1 - .../workflow/action/ZOA_STATUS_RFCAction.java | 100 +++++----- .../action/ZSR_PUR_INFO_OEM_Action.java | 3 +- 13 files changed, 454 insertions(+), 414 deletions(-) diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ARSPaymentRecepitAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ARSPaymentRecepitAction.java index 58fb64a..e66b365 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ARSPaymentRecepitAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ARSPaymentRecepitAction.java @@ -92,7 +92,10 @@ public class ARSPaymentRecepitAction extends BaseBean implements Action, EsbServ String currencyCode = ""; String poolname = CONN_TYPE.ebuilder.getType(); // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - rs.executeSql("select currencyCode from e10_common.dbo.uf_eas_currency where id=" + map.get("BZ"), poolname); + String sql = "select currencyCode from e10_common.dbo.uf_eas_currency where id=" + map.get("BZ"); + logger_c29b3679.info( "sql--" + sql) ; + boolean b1 = rs.executeSql(sql, poolname); + logger_c29b3679.info( "sql flag = " + b1) ; while (rs.next()) { currencyCode = rs.getString("currencyCode"); logger_c29b3679.info( "currencyCode--" + currencyCode) ; 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 fe235cd..03d72b8 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 @@ -230,18 +230,22 @@ public class AddVenMatExtsToSrmAction extends BaseBean implements Action, EsbSer } // RecordSet rs = new RecordSet(); String sql = "update e10_core_business.dbo." + tablename + " set state='" + isTat + "',message='" + msg + "' where requestId=" + requestId; + logger_336cd654.info("sql == "+sql); String poolname_c1 = CONN_TYPE.workflow.getType(); // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - rs.executeSql(sql, poolname_c1); + boolean b1 = rs.executeSql(sql, poolname_c1); + logger_336cd654.info("sql flag == "+b1); } catch (Exception e) { request.getRequestManager().setMessageid("error"); request.getRequestManager().setMessagecontent("SRM接口返回错误信息：" + e.toString()); logger_336cd654.info(String.valueOf(requestId + "AddVenMatExtsToSrmAction-Request出错: " + e.toString())); RecordSet rs = I18nContextUtil.getBean(RecordSet.class); String sql = "update e10_core_business.dbo." + tablename + " set state='E',message='" + e.getMessage() + "' where requestId=" + requestId; + logger_336cd654.info("sql == "+sql); String poolname = CONN_TYPE.workflow.getType(); // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - rs.executeSql(sql, poolname); + boolean b1 = rs.executeSql(sql, poolname); + logger_336cd654.info("sql err flag == "+b1); return WeaResult.fail(500, "执行失败", getResultMapForAction(weaverResultMap, "result", FAILURE_AND_CONTINUE, request.getRequestManager())); } return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, request.getRequestManager())); 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 c239e77..7b67c39 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 @@ -159,13 +159,17 @@ public class BlackListTempThawCheckAction extends BaseBean implements Action, Es public String getApplyCom(String id, String table) { RecordSet rs = I18nContextUtil.getBean(RecordSet.class); String sql = "select lrhmddw from e10_core_business.dbo." + table + " where requestId=" + id; + + logger_454fb322.info("getApplyCom sql == " + sql); String poolname = CONN_TYPE.workflow.getType(); // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - rs.executeSql(sql, poolname); + boolean b1 = rs.executeSql(sql, poolname); + logger_454fb322.info("getApplyCom sql flag== " + b1); String lrhmddw = ""; if (rs.next()) { lrhmddw = Util.null2String(rs.getString("lrhmddw")); } + logger_454fb322.info("getApplyCom lrhmddw= " + lrhmddw); return lrhmddw; } 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 1ab2d9e..fb42b92 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 @@ -57,7 +57,10 @@ public class BuQianKaAction extends BaseBean implements Action, EsbServerlessRpc String poolname = CONN_TYPE.hrm.getType(); // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - rs.executeSql(createsqlString, poolname); + boolean b11 = rs.executeSql(createsqlString, poolname); + + logger_f1f35583.info(String.valueOf("createsqlString flag === " + b11)); + rs.next(); String createrId = rs.getString("id"); Map mainTableDataMap = new HashMap(); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ChangeOrgRoleAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ChangeOrgRoleAction.java index 4f22a22..ff85bd2 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ChangeOrgRoleAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ChangeOrgRoleAction.java @@ -22,6 +22,9 @@ import com.weaver.verupgrade.hrm.resource.ResourceComInfo; import com.weaver.verupgrade.soa.workflow.request.Property; import com.weaver.verupgrade.interfaces.workflow.action.Action; + + +//不启用 @org.springframework.stereotype.Service("workflow_action_ChangeOrgRoleAction") public class ChangeOrgRoleAction extends BaseBean implements Action, EsbServerlessRpcRemoteInterface { @@ -38,57 +41,58 @@ public class ChangeOrgRoleAction extends BaseBean implements Action, EsbServerle RequestInfo request = requestInfoTemp.getRequestInfo(requestIdTemp, userIdTemp); try { String requestid = request.getRequestid(); - try { - logger_c08ea2e1.info(String.valueOf(requestid + "开始修改组织架构权限")); - Property[] properties = request.getMainTableInfo().getProperty(); - Map map = new HashMap(); - for (int i = 0; i < properties.length; i++) { - String name = properties[i].getName().toUpperCase(); - String value = Util.null2String(properties[i].getValue()); - map.put(name, value); - } - String org = ""; - String role = ""; - String sql = ""; - String resorceid = map.get("XJSYY"); - RecordSet rs = I18nContextUtil.getBean(RecordSet.class); - if ("0".equals(map.get("ZZJGGG"))) { - org = map.get("XTZGS"); - role = map.get("XTZFBJS"); - role = role.substring(role.indexOf("_") + 1); - sql = "update formdata_detail as HrmSubcompanyDefined set " + role + "='" + resorceid + "' where subcomid=" + org; - String poolname_i8 = CONN_TYPE.workflow.getType(); - // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - rs.executeSql(sql, poolname_i8); - SubCompanyComInfo subCompanyComInfo = I18nContextUtil.getBean(SubCompanyComInfo.class); - subCompanyComInfo.removeCompanyCache(); - String poolname_v1 = CONN_TYPE.workflow.getType(); - // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - rs.executeSql("UPDATE orgchartstate SET orgchartstate.needupdate = 1 WHERE orgchartstate.delete_type = 0 AND orgchartstate.tenant_key = 't6kj9c07jr'", poolname_v1); - //TODO config -// MatrixUtil.updateSubcompayData(org); - } else if ("1".equals(map.get("ZZJGGG"))) { - org = map.get("XTZBM"); - role = map.get("XTZBMJS"); - role = role.substring(role.indexOf("_") + 1); - sql = "update HrmDepartmentDefined set " + role + "='" + resorceid + "' where deptid=" + org; - String poolname = CONN_TYPE.workflow.getType(); - // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - rs.executeSql(sql, poolname); - DepartmentComInfo departmentComInfo = I18nContextUtil.getBean(DepartmentComInfo.class); - departmentComInfo.removeCompanyCache(); - ResourceComInfo ResourceComInfo = I18nContextUtil.getBean(ResourceComInfo.class); - ResourceComInfo.removeResourceCache(); - String poolname_ou = CONN_TYPE.workflow.getType(); - // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - rs.executeSql("UPDATE orgchartstate SET orgchartstate.needupdate = 1 WHERE orgchartstate.delete_type = 0 AND orgchartstate.tenant_key = 't6kj9c07jr'", poolname_ou); - //TODO config -// MatrixUtil.updateDepartmentData(org); - } - logger_c08ea2e1.info(String.valueOf(requestid + "修改组织架构权限结束")); - } catch (Exception e) { - logger_c08ea2e1.info(String.valueOf(requestid + "修改组织架构权限出错：" + e.toString())); - } + //TODO custom 不启用 +// try { +// logger_c08ea2e1.info(String.valueOf(requestid + "开始修改组织架构权限")); +// Property[] properties = request.getMainTableInfo().getProperty(); +// Map map = new HashMap(); +// for (int i = 0; i < properties.length; i++) { +// String name = properties[i].getName().toUpperCase(); +// String value = Util.null2String(properties[i].getValue()); +// map.put(name, value); +// } +// String org = ""; +// String role = ""; +// String sql = ""; +// String resorceid = map.get("XJSYY"); +// RecordSet rs = I18nContextUtil.getBean(RecordSet.class); +// if ("0".equals(map.get("ZZJGGG"))) { +// org = map.get("XTZGS"); +// role = map.get("XTZFBJS"); +// role = role.substring(role.indexOf("_") + 1); +// sql = "update formdata_detail as HrmSubcompanyDefined set " + role + "='" + resorceid + "' where subcomid=" + org; +// String poolname_i8 = CONN_TYPE.workflow.getType(); +// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 +// rs.executeSql(sql, poolname_i8); +// SubCompanyComInfo subCompanyComInfo = I18nContextUtil.getBean(SubCompanyComInfo.class); +// subCompanyComInfo.removeCompanyCache(); +// String poolname_v1 = CONN_TYPE.workflow.getType(); +// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 +// rs.executeSql("UPDATE orgchartstate SET orgchartstate.needupdate = 1 WHERE orgchartstate.delete_type = 0 AND orgchartstate.tenant_key = 't6kj9c07jr'", poolname_v1); +// //TODO config +//// MatrixUtil.updateSubcompayData(org); +// } else if ("1".equals(map.get("ZZJGGG"))) { +// org = map.get("XTZBM"); +// role = map.get("XTZBMJS"); +// role = role.substring(role.indexOf("_") + 1); +// sql = "update HrmDepartmentDefined set " + role + "='" + resorceid + "' where deptid=" + org; +// String poolname = CONN_TYPE.workflow.getType(); +// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 +// rs.executeSql(sql, poolname); +// DepartmentComInfo departmentComInfo = I18nContextUtil.getBean(DepartmentComInfo.class); +// departmentComInfo.removeCompanyCache(); +// ResourceComInfo ResourceComInfo = I18nContextUtil.getBean(ResourceComInfo.class); +// ResourceComInfo.removeResourceCache(); +// String poolname_ou = CONN_TYPE.workflow.getType(); +// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 +// rs.executeSql("UPDATE orgchartstate SET orgchartstate.needupdate = 1 WHERE orgchartstate.delete_type = 0 AND orgchartstate.tenant_key = 't6kj9c07jr'", poolname_ou); +// //TODO config +//// MatrixUtil.updateDepartmentData(org); +// } +// logger_c08ea2e1.info(String.valueOf(requestid + "修改组织架构权限结束")); +// } catch (Exception e) { +// logger_c08ea2e1.info(String.valueOf(requestid + "修改组织架构权限出错：" + e.toString())); +// } 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/CloseAccountAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/CloseAccountAction.java index c004f57..b8a0b8c 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 @@ -27,6 +27,9 @@ import com.weaver.verupgrade.soa.workflow.request.Property; import com.weaver.verupgrade.soa.workflow.request.Row; import com.weaver.verupgrade.interfaces.workflow.action.Action; + + +//不启用 @org.springframework.stereotype.Service("workflow_action_CloseAccountAction") public class CloseAccountAction extends BaseBean implements Action, EsbServerlessRpcRemoteInterface { @@ -59,91 +62,92 @@ public class CloseAccountAction extends BaseBean implements Action, EsbServerles String status = ""; String message = ""; String sql_error = ""; - try { - // 用户工号 - String yhgh = ""; - Property[] properties = request.getMainTableInfo().getProperty(); - for (int i = 0; i < properties.length; i++) { - String name = properties[i].getName().toUpperCase(); - String value = Util.null2String(properties[i].getValue()); - if (name.equals("YHGH")) { - yhgh = value; - } - } - DetailTable[] detailtable = request.getDetailTableInfo().getDetailTable(); - DetailTable dtq = detailtable[0]; - Row[] sq = dtq.getRow(); - SI_HTPortalUAMGMT2_OUTServiceStub.UserSyncInfo[] param = new SI_HTPortalUAMGMT2_OUTServiceStub.UserSyncInfo[sq.length]; - SI_HTPortalUAMGMT2_OUTServiceStub.UserSyncInfo paramInfo = new SI_HTPortalUAMGMT2_OUTServiceStub.UserSyncInfo(); - logger_ac56032a.info("sq -- "+ sq); - for (int j = 0; j < sq.length; j++) { - Row rq = sq[j]; - Cell[] cq = rq.getCell(); - paramInfo.setMail(""); - paramInfo.setOperation("disable"); - paramInfo.setUserid(yhgh); - for (int k = 0; k < cq.length; k++) { - Cell cq1 = cq[k]; - String nameq = cq1.getName().toUpperCase(); - String valueq = Util.null2String(cq1.getValue()); - if (nameq.equals("XTBH")) { - paramInfo.setSystemid(valueq); - } - } - param[j] = paramInfo; - } -// AccountService service = new AccountService(); - logger_ac56032a.info("param--"+ param); - StringBuilder sb = new StringBuilder(); - String[] array = service.account("HT01EIP006", param); - logger_ac56032a.info("array--"+ array); - if ("E".equals(array[0])) { - status = array[0]; - message = array[1]; - logger_ac56032a.info(String.valueOf(requestId + "---" + yhgh + "调用批量销户接口出错：" + array[1])); - } else { - JSONObject jsonObject = JSONObject.parseObject(array[1]); - JSONArray jsonArray = jsonObject.getJSONArray("returnMsg"); - for (int i = 0; i < jsonArray.size(); i++) { - JSONObject jsonObjectone = jsonArray.getJSONObject(i); - String result = jsonObjectone.getString("result"); - String systemid = jsonObjectone.getString("systemid"); - String stat = jsonObjectone.getString("stat"); - if ("0".equals(stat)) { - sb.append(systemid + ":" + result + ";"); - } - } - if (sb.length() > 0) { - status = "E"; - message = sb.toString(); - logger_ac56032a.info(String.valueOf(requestId + "---" + yhgh + "批量销户失败" + message)); - } else { - status = "S"; - message = "销户成功"; - logger_ac56032a.info(String.valueOf(requestId + "---" + yhgh + "批量销户成功")); - } - } - sql_error = "update e10_core_business.dbo." + 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); - if ("E".equals(status)) { - logger_ac56032a.info(String.valueOf(requestId + "---" + yhgh + "批量销户[" + message + "]")); - request.getRequestManager().setMessageid("ERROR"); - request.getRequestManager().setMessagecontent("门户返回错误信息：" + message); - } - } catch (Exception e) { - sql_error = "update e10_core_business.dbo." + 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())); - } + //TODO custom 不启用 +// try { +// // 用户工号 +// String yhgh = ""; +// Property[] properties = request.getMainTableInfo().getProperty(); +// for (int i = 0; i < properties.length; i++) { +// String name = properties[i].getName().toUpperCase(); +// String value = Util.null2String(properties[i].getValue()); +// if (name.equals("YHGH")) { +// yhgh = value; +// } +// } +// DetailTable[] detailtable = request.getDetailTableInfo().getDetailTable(); +// DetailTable dtq = detailtable[0]; +// Row[] sq = dtq.getRow(); +// SI_HTPortalUAMGMT2_OUTServiceStub.UserSyncInfo[] param = new SI_HTPortalUAMGMT2_OUTServiceStub.UserSyncInfo[sq.length]; +// SI_HTPortalUAMGMT2_OUTServiceStub.UserSyncInfo paramInfo = new SI_HTPortalUAMGMT2_OUTServiceStub.UserSyncInfo(); +// logger_ac56032a.info("sq -- "+ sq); +// for (int j = 0; j < sq.length; j++) { +// Row rq = sq[j]; +// Cell[] cq = rq.getCell(); +// paramInfo.setMail(""); +// paramInfo.setOperation("disable"); +// paramInfo.setUserid(yhgh); +// for (int k = 0; k < cq.length; k++) { +// Cell cq1 = cq[k]; +// String nameq = cq1.getName().toUpperCase(); +// String valueq = Util.null2String(cq1.getValue()); +// if (nameq.equals("XTBH")) { +// paramInfo.setSystemid(valueq); +// } +// } +// param[j] = paramInfo; +// } +//// AccountService service = new AccountService(); +// logger_ac56032a.info("param--"+ param); +// StringBuilder sb = new StringBuilder(); +// String[] array = service.account("HT01EIP006", param); +// logger_ac56032a.info("array--"+ array); +// if ("E".equals(array[0])) { +// status = array[0]; +// message = array[1]; +// logger_ac56032a.info(String.valueOf(requestId + "---" + yhgh + "调用批量销户接口出错：" + array[1])); +// } else { +// JSONObject jsonObject = JSONObject.parseObject(array[1]); +// JSONArray jsonArray = jsonObject.getJSONArray("returnMsg"); +// for (int i = 0; i < jsonArray.size(); i++) { +// JSONObject jsonObjectone = jsonArray.getJSONObject(i); +// String result = jsonObjectone.getString("result"); +// String systemid = jsonObjectone.getString("systemid"); +// String stat = jsonObjectone.getString("stat"); +// if ("0".equals(stat)) { +// sb.append(systemid + ":" + result + ";"); +// } +// } +// if (sb.length() > 0) { +// status = "E"; +// message = sb.toString(); +// logger_ac56032a.info(String.valueOf(requestId + "---" + yhgh + "批量销户失败" + message)); +// } else { +// status = "S"; +// message = "销户成功"; +// logger_ac56032a.info(String.valueOf(requestId + "---" + yhgh + "批量销户成功")); +// } +// } +// sql_error = "update e10_core_business.dbo." + 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); +// if ("E".equals(status)) { +// logger_ac56032a.info(String.valueOf(requestId + "---" + yhgh + "批量销户[" + message + "]")); +// request.getRequestManager().setMessageid("ERROR"); +// request.getRequestManager().setMessagecontent("门户返回错误信息：" + message); +// } +// } catch (Exception e) { +// sql_error = "update e10_core_business.dbo." + 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(); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/EAS_VoucherModifyAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/EAS_VoucherModifyAction.java index ab22c16..948066e 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/EAS_VoucherModifyAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/EAS_VoucherModifyAction.java @@ -28,6 +28,8 @@ import com.weaver.verupgrade.soa.workflow.request.*; import com.weaver.verupgrade.soa.workflow.request.Property; import com.weaver.verupgrade.interfaces.workflow.action.Action; + +//不启用 /** * EAS007电子档案凭证号修改流程 * 接口账号密码 测试环境-都为空 正式环境：eas/qwerfdsa @@ -65,94 +67,95 @@ public class EAS_VoucherModifyAction extends BaseBean implements Action, EsbServ String USERNAME = "eas"; // 接口密码 String PASSWORD = "qwerfdsa"; - try { - ResourceComInfo hr = I18nContextUtil.getBean(ResourceComInfo.class); - BillFieldUtil unit = new BillFieldUtil(); - Property[] properties = requestInfo.getMainTableInfo().getProperty(); - requestID = requestInfo.getRequestid(); - logger_57237c37.info(String.valueOf("EAS_VoucherModifyAction--start--" + requestID)); - String lastopertorid = requestInfo.getLastoperator(); - Map mMap = new HashMap(); - for (int i = 0; i < properties.length; i++) { - String name = properties[i].getName().toUpperCase(); - String value = Util.null2String(properties[i].getValue()); - mMap.put(name, value); - } - String boeNum = mMap.get("DJH"); - logger_57237c37.info(String.valueOf("报账单号：" + boeNum)); - String kjqj = mMap.get("BGPZKJQJ"); - if (kjqj != null && !kjqj.equals("")) { - kjqj = kjqj.replaceAll("-", ""); - } - logger_57237c37.info(String.valueOf("凭证变更会计期间：" + kjqj)); - String sqrq = mMap.get("SQRQ"); - if (sqrq != null && !sqrq.equals("")) { - sqrq = sqrq.replaceAll("-", ""); - } - logger_57237c37.info(String.valueOf("申请日期：" + sqrq)); - String sqr = mMap.get("SQR"); - String sqrcode = ""; - if (!sqr.equals("")) { - // 申请人工号 - sqrcode = unit.getWorkcode(sqr); - } - logger_57237c37.info(String.valueOf("申请人工号：" + sqrcode)); - String hsdwbm = mMap.get("HSDWDM"); - logger_57237c37.info(String.valueOf("核算单位编码：" + hsdwbm)); - String lcbh = mMap.get("LCBH"); - logger_57237c37.info(String.valueOf("OA流程号：" + lcbh)); - String zt = mMap.get("ZT"); - logger_57237c37.info(String.valueOf("主题：" + zt)); - String bgqpzh = mMap.get("BGQPZH"); - logger_57237c37.info(String.valueOf("变更前凭证号：" + bgqpzh)); - String bghpzh = mMap.get("BGHPZH"); - logger_57237c37.info(String.valueOf("变更后凭证号：" + bghpzh)); - SieOaVoucherServiceStub.SieOaVoucherDO param = new SieOaVoucherServiceStub.SieOaVoucherDO(); - param.setITFID(ITFID); - param.setSYSID(SYSID); - param.setUSERNAME(USERNAME); - param.setPASSWORD(PASSWORD); - // 保障单号 - param.setBoeNum(boeNum); - // 会计期间 - param.setAccPeriod(kjqj); - // 申请日期 - param.setApplyDate(sqrq); - // 申请人工号 - param.setApplyEmployeeNo(sqrcode); - // 核算单位编码 - param.setCompanyCode(hsdwbm); - // oa流程号 - param.setFlowNoOA(lcbh); - param.setRequestId(requestID); - // 主题 - param.setSubject(zt); - // 新凭证号 - param.setVoucherNoNew(bghpzh); - // 原凭证号 - param.setVoucherNoOld(bgqpzh); - // 调用接口 -// String url = Util.null2String(I18nContextUtilcus.getBean(Environment.class).getProperty("hteasoasync.updatevoucherurl")).trim(); - String url = configProp.getUpdatevoucherurl(); - logger_57237c37.info("url == " + url); - CallSieOAVoucherService service = new CallSieOAVoucherService(url); - String[] result = service.syncVoucherInfo(param); - logger_57237c37.info(String.valueOf("调用借阅审批回调接口返回值：" + result)); - if (!"S".equals(result[0])) { - // 失败 - logger_57237c37.info(String.valueOf("报账系统返回错误信息：" + result[1])); - requestInfo.getRequestManager().setMessageid("ERROR"); - requestInfo.getRequestManager().setMessagecontent("报账系统返回错误信息：" + result[1]); - return WeaResult.fail(500, "执行失败", getResultMapForAction(weaverResultMap, "result", FAILURE_AND_CONTINUE, requestInfo.getRequestManager())); - } - } catch (Exception e) { - logger_57237c37.info(String.valueOf("提交失败！")); - logger_57237c37.info(String.valueOf("Error======" + e.getMessage())); - requestInfo.getRequestManager().setMessageid("ERROR"); - requestInfo.getRequestManager().setMessagecontent("提交失败！"); - // return FAILURE_AND_CONTINUE; - return WeaResult.fail(500, "执行失败", getResultMapForAction(weaverResultMap, "result", FAILURE_AND_CONTINUE, requestInfo.getRequestManager())); - } + //TODO custom 不启用 +// try { +// ResourceComInfo hr = I18nContextUtil.getBean(ResourceComInfo.class); +// BillFieldUtil unit = new BillFieldUtil(); +// Property[] properties = requestInfo.getMainTableInfo().getProperty(); +// requestID = requestInfo.getRequestid(); +// logger_57237c37.info(String.valueOf("EAS_VoucherModifyAction--start--" + requestID)); +// String lastopertorid = requestInfo.getLastoperator(); +// Map mMap = new HashMap(); +// for (int i = 0; i < properties.length; i++) { +// String name = properties[i].getName().toUpperCase(); +// String value = Util.null2String(properties[i].getValue()); +// mMap.put(name, value); +// } +// String boeNum = mMap.get("DJH"); +// logger_57237c37.info(String.valueOf("报账单号：" + boeNum)); +// String kjqj = mMap.get("BGPZKJQJ"); +// if (kjqj != null && !kjqj.equals("")) { +// kjqj = kjqj.replaceAll("-", ""); +// } +// logger_57237c37.info(String.valueOf("凭证变更会计期间：" + kjqj)); +// String sqrq = mMap.get("SQRQ"); +// if (sqrq != null && !sqrq.equals("")) { +// sqrq = sqrq.replaceAll("-", ""); +// } +// logger_57237c37.info(String.valueOf("申请日期：" + sqrq)); +// String sqr = mMap.get("SQR"); +// String sqrcode = ""; +// if (!sqr.equals("")) { +// // 申请人工号 +// sqrcode = unit.getWorkcode(sqr); +// } +// logger_57237c37.info(String.valueOf("申请人工号：" + sqrcode)); +// String hsdwbm = mMap.get("HSDWDM"); +// logger_57237c37.info(String.valueOf("核算单位编码：" + hsdwbm)); +// String lcbh = mMap.get("LCBH"); +// logger_57237c37.info(String.valueOf("OA流程号：" + lcbh)); +// String zt = mMap.get("ZT"); +// logger_57237c37.info(String.valueOf("主题：" + zt)); +// String bgqpzh = mMap.get("BGQPZH"); +// logger_57237c37.info(String.valueOf("变更前凭证号：" + bgqpzh)); +// String bghpzh = mMap.get("BGHPZH"); +// logger_57237c37.info(String.valueOf("变更后凭证号：" + bghpzh)); +// SieOaVoucherServiceStub.SieOaVoucherDO param = new SieOaVoucherServiceStub.SieOaVoucherDO(); +// param.setITFID(ITFID); +// param.setSYSID(SYSID); +// param.setUSERNAME(USERNAME); +// param.setPASSWORD(PASSWORD); +// // 保障单号 +// param.setBoeNum(boeNum); +// // 会计期间 +// param.setAccPeriod(kjqj); +// // 申请日期 +// param.setApplyDate(sqrq); +// // 申请人工号 +// param.setApplyEmployeeNo(sqrcode); +// // 核算单位编码 +// param.setCompanyCode(hsdwbm); +// // oa流程号 +// param.setFlowNoOA(lcbh); +// param.setRequestId(requestID); +// // 主题 +// param.setSubject(zt); +// // 新凭证号 +// param.setVoucherNoNew(bghpzh); +// // 原凭证号 +// param.setVoucherNoOld(bgqpzh); +// // 调用接口 +//// String url = Util.null2String(I18nContextUtilcus.getBean(Environment.class).getProperty("hteasoasync.updatevoucherurl")).trim(); +// String url = configProp.getUpdatevoucherurl(); +// logger_57237c37.info("url == " + url); +// CallSieOAVoucherService service = new CallSieOAVoucherService(url); +// String[] result = service.syncVoucherInfo(param); +// logger_57237c37.info(String.valueOf("调用借阅审批回调接口返回值：" + result)); +// if (!"S".equals(result[0])) { +// // 失败 +// logger_57237c37.info(String.valueOf("报账系统返回错误信息：" + result[1])); +// requestInfo.getRequestManager().setMessageid("ERROR"); +// requestInfo.getRequestManager().setMessagecontent("报账系统返回错误信息：" + result[1]); +// return WeaResult.fail(500, "执行失败", getResultMapForAction(weaverResultMap, "result", FAILURE_AND_CONTINUE, requestInfo.getRequestManager())); +// } +// } catch (Exception e) { +// logger_57237c37.info(String.valueOf("提交失败！")); +// logger_57237c37.info(String.valueOf("Error======" + e.getMessage())); +// requestInfo.getRequestManager().setMessageid("ERROR"); +// requestInfo.getRequestManager().setMessagecontent("提交失败！"); +// // return FAILURE_AND_CONTINUE; +// return WeaResult.fail(500, "执行失败", getResultMapForAction(weaverResultMap, "result", FAILURE_AND_CONTINUE, requestInfo.getRequestManager())); +// } return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestInfo.getRequestManager())); } catch (Exception e) { e.printStackTrace(); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/UpdateSeclevelAndpasswordlock.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/UpdateSeclevelAndpasswordlock.java index cf9f0eb..fd52bcd 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/UpdateSeclevelAndpasswordlock.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/UpdateSeclevelAndpasswordlock.java @@ -21,6 +21,9 @@ import com.weaver.verupgrade.soa.workflow.request.DetailTable; import com.weaver.verupgrade.soa.workflow.request.Row; import com.weaver.verupgrade.interfaces.workflow.action.Action; + + +//不启用 @org.springframework.stereotype.Service("workflow_action_UpdateSeclevelAndpasswordlock") public class UpdateSeclevelAndpasswordlock extends BaseBean implements Action, EsbServerlessRpcRemoteInterface { @@ -43,53 +46,54 @@ public class UpdateSeclevelAndpasswordlock extends BaseBean implements Action, E DetailTable dtq = detailtable[0]; Row[] sq = dtq.getRow(); RecordSet rs = I18nContextUtil.getBean(RecordSet.class); - try { - for (int j = 0; j < sq.length; j++) { - // 指定行 - Row rq = sq[j]; - // 每行数据再按列存储 - Cell[] cq = rq.getCell(); - Map map = new HashMap(); - for (int k = 0; k < cq.length; k++) { - // 指定列 - Cell cq1 = cq[k]; - // 明细字段名称 - String nameq = cq1.getName().toLowerCase(); - String valueq = Util.null2String(cq1.getValue()); - map.put(nameq, valueq); - } - if (map.get("xglx").equals("0")) { - String userid = map.get("xgyhxm"); - String seclevel = map.get("xaqjb"); - String sql = "update eteams.dbo.employee as hrmresource set seclevel=" + seclevel + " where id=" + userid; - logger_54eacf62.info(String.valueOf("修改安全级别和密码解锁sql:" + sql)); - String poolname = CONN_TYPE.workflow.getType(); - // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - rs.executeSql(sql, poolname); - } - if (map.get("xglx").equals("1")) { - String userid = map.get("xgyhxm"); - String sql = "update employee as hrmresource set passwordlock=0 where id=" + userid; - logger_54eacf62.info(String.valueOf("修改安全级别和密码解锁sql:" + sql)); - String poolname_ow = CONN_TYPE.workflow.getType(); - // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - rs.executeSql(sql, poolname_ow); - } - if (map.get("xglx").equals("2")) { - String userid = map.get("xgyhxm"); - String seclevel = map.get("xaqjb"); - String sql = "update eteams.dbo.employee as hrmresource set passwordlock=0,seclevel=" + seclevel + " where id=" + userid; - logger_54eacf62.info(String.valueOf("修改安全级别和密码解锁sql:" + sql)); - String poolname_fw = CONN_TYPE.workflow.getType(); - // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - rs.executeSql(sql, poolname_fw); - } - } - logger_54eacf62.info(String.valueOf(requestid + "修改安全级别和密码解锁结束")); - } catch (Exception e) { - logger_54eacf62.info(String.valueOf("修改安全级别和密码解锁出错：" + e.toString())); - return WeaResult.fail(500, "出错啦", getResultMapForAction(weaverResultMap, "result", "", request.getRequestManager())); - } + //TODO custom 不启用 +// try { +// for (int j = 0; j < sq.length; j++) { +// // 指定行 +// Row rq = sq[j]; +// // 每行数据再按列存储 +// Cell[] cq = rq.getCell(); +// Map map = new HashMap(); +// for (int k = 0; k < cq.length; k++) { +// // 指定列 +// Cell cq1 = cq[k]; +// // 明细字段名称 +// String nameq = cq1.getName().toLowerCase(); +// String valueq = Util.null2String(cq1.getValue()); +// map.put(nameq, valueq); +// } +// if (map.get("xglx").equals("0")) { +// String userid = map.get("xgyhxm"); +// String seclevel = map.get("xaqjb"); +// String sql = "update eteams.dbo.employee as hrmresource set seclevel=" + seclevel + " where id=" + userid; +// logger_54eacf62.info(String.valueOf("修改安全级别和密码解锁sql:" + sql)); +// String poolname = CONN_TYPE.workflow.getType(); +// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 +// rs.executeSql(sql, poolname); +// } +// if (map.get("xglx").equals("1")) { +// String userid = map.get("xgyhxm"); +// String sql = "update employee as hrmresource set passwordlock=0 where id=" + userid; +// logger_54eacf62.info(String.valueOf("修改安全级别和密码解锁sql:" + sql)); +// String poolname_ow = CONN_TYPE.workflow.getType(); +// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 +// rs.executeSql(sql, poolname_ow); +// } +// if (map.get("xglx").equals("2")) { +// String userid = map.get("xgyhxm"); +// String seclevel = map.get("xaqjb"); +// String sql = "update eteams.dbo.employee as hrmresource set passwordlock=0,seclevel=" + seclevel + " where id=" + userid; +// logger_54eacf62.info(String.valueOf("修改安全级别和密码解锁sql:" + sql)); +// String poolname_fw = CONN_TYPE.workflow.getType(); +// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 +// rs.executeSql(sql, poolname_fw); +// } +// } +// logger_54eacf62.info(String.valueOf(requestid + "修改安全级别和密码解锁结束")); +// } catch (Exception e) { +// logger_54eacf62.info(String.valueOf("修改安全级别和密码解锁出错：" + 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(); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_PRICE_RFCAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_PRICE_RFCAction.java index 058e4a9..f33a6fb 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_PRICE_RFCAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_PRICE_RFCAction.java @@ -24,6 +24,8 @@ import com.weaver.verupgrade.general.Util; import com.weaver.verupgrade.soa.workflow.request.Property; import com.weaver.verupgrade.interfaces.workflow.action.Action; + +// 不启用 @org.springframework.stereotype.Service("workflow_action_ZOA_PRICE_RFCAction") public class ZOA_PRICE_RFCAction extends BaseBean implements Action, EsbServerlessRpcRemoteInterface { @@ -57,50 +59,51 @@ public class ZOA_PRICE_RFCAction extends BaseBean implements Action, EsbServerle String tablename = requestinfo.getRequestManager().getBillTableName(); String requestId = requestinfo.getRequestid(); retstr = new String[2]; - try { - String sapId = ""; - Property[] aproperty = requestinfo.getMainTableInfo().getProperty(); - for (int i = 0; i < aproperty.length; i++) { - String name = aproperty[i].getName().toUpperCase(); - String value = Util.null2String(aproperty[i].getValue()); - if (name.equals("BH")) { - sapId = value; - } - } - RecordSetTrans recordsettrans = I18nContextUtil.getBean(RecordSetTrans.class); - recordsettrans.setAutoCommit(false); - JCoFunction jcofunction = destination.getRepository().getFunction("ZOA_PRICE_RFC"); - if (jcofunction == null) { - logger_489475fd.info(String.valueOf("ZOA_PRICE_RFC not found in SAP.")); - retstr[0] = "E"; - retstr[1] = "没找到SAP的ZOA_PRICE_RFC函数"; - } else { - jcofunction.getImportParameterList().setValue("ID", sapId); - logger_489475fd.info(String.valueOf("开始调用ZOA_PRICE_RFC函数")); - jcofunction.execute(destination); - retstr[0] = jcofunction.getExportParameterList().getValue("E_STATUS").toString(); - retstr[1] = jcofunction.getExportParameterList().getValue("E_MESSAGE").toString(); - logger_489475fd.info(String.valueOf("调用ZOA_PRICE_RFC函数成功：" + retstr[0] + "," + retstr[1])); - } - String sql = "update e10_core_business.dbo." + tablename + " set jgfb= '" + retstr[0] + "',message='" + retstr[1] + "' where id =" + requestId; - String poolname_sg = CONN_TYPE.workflow.getType(); - // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - rs.executeSql(sql, poolname_sg); - if (!"S".equals(retstr[0])) { - requestinfo.getRequestManager().setMessageid("ERROR"); - requestinfo.getRequestManager().setMessagecontent("SAP返回的错误信息：" + retstr[1]); - return WeaResult.fail(500, "执行异常", getResultMapForAction(weaverResultMap, "result", retstr[1], requestinfo.getRequestManager())); - } - } catch (Exception e) { - logger_489475fd.info(String.valueOf("调用ZOA_PRICE_RFC查询价格是否发布出错：" + e.toString())); - requestinfo.getRequestManager().setMessageid("ERROR"); - requestinfo.getRequestManager().setMessagecontent("调用SAP函数出错：：" + e.getMessage()); - String sql = "update e10_core_business.dbo." + tablename + " set jgfb= '" + retstr[0] + "',message='" + retstr[1] + "' where id =" + requestId; - String poolname = CONN_TYPE.workflow.getType(); - // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - rs.executeSql(sql, poolname); - return WeaResult.fail(500, "执行异常", getResultMapForAction(weaverResultMap, "result", e.getMessage(), requestinfo.getRequestManager())); - } + //TODO custom 不启用 +// try { +// String sapId = ""; +// Property[] aproperty = requestinfo.getMainTableInfo().getProperty(); +// for (int i = 0; i < aproperty.length; i++) { +// String name = aproperty[i].getName().toUpperCase(); +// String value = Util.null2String(aproperty[i].getValue()); +// if (name.equals("BH")) { +// sapId = value; +// } +// } +// RecordSetTrans recordsettrans = I18nContextUtil.getBean(RecordSetTrans.class); +// recordsettrans.setAutoCommit(false); +// JCoFunction jcofunction = destination.getRepository().getFunction("ZOA_PRICE_RFC"); +// if (jcofunction == null) { +// logger_489475fd.info(String.valueOf("ZOA_PRICE_RFC not found in SAP.")); +// retstr[0] = "E"; +// retstr[1] = "没找到SAP的ZOA_PRICE_RFC函数"; +// } else { +// jcofunction.getImportParameterList().setValue("ID", sapId); +// logger_489475fd.info(String.valueOf("开始调用ZOA_PRICE_RFC函数")); +// jcofunction.execute(destination); +// retstr[0] = jcofunction.getExportParameterList().getValue("E_STATUS").toString(); +// retstr[1] = jcofunction.getExportParameterList().getValue("E_MESSAGE").toString(); +// logger_489475fd.info(String.valueOf("调用ZOA_PRICE_RFC函数成功：" + retstr[0] + "," + retstr[1])); +// } +// String sql = "update e10_core_business.dbo." + tablename + " set jgfb= '" + retstr[0] + "',message='" + retstr[1] + "' where id =" + requestId; +// String poolname_sg = CONN_TYPE.workflow.getType(); +// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 +// rs.executeSql(sql, poolname_sg); +// if (!"S".equals(retstr[0])) { +// requestinfo.getRequestManager().setMessageid("ERROR"); +// requestinfo.getRequestManager().setMessagecontent("SAP返回的错误信息：" + retstr[1]); +// return WeaResult.fail(500, "执行异常", getResultMapForAction(weaverResultMap, "result", retstr[1], requestinfo.getRequestManager())); +// } +// } catch (Exception e) { +// logger_489475fd.info(String.valueOf("调用ZOA_PRICE_RFC查询价格是否发布出错：" + e.toString())); +// requestinfo.getRequestManager().setMessageid("ERROR"); +// requestinfo.getRequestManager().setMessagecontent("调用SAP函数出错：：" + e.getMessage()); +// String sql = "update e10_core_business.dbo." + tablename + " set jgfb= '" + retstr[0] + "',message='" + retstr[1] + "' where id =" + requestId; +// String poolname = CONN_TYPE.workflow.getType(); +// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 +// rs.executeSql(sql, poolname); +// return WeaResult.fail(500, "执行异常", getResultMapForAction(weaverResultMap, "result", e.getMessage(), requestinfo.getRequestManager())); +// } return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager())); } catch (Exception e) { e.printStackTrace(); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_SIGN_RFCAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_SIGN_RFCAction.java index 39b5911..7016e39 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_SIGN_RFCAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_SIGN_RFCAction.java @@ -23,6 +23,9 @@ import com.weaver.verupgrade.general.Util; import com.weaver.verupgrade.soa.workflow.request.Property; import com.weaver.verupgrade.interfaces.workflow.action.Action; + + +//不启用 @org.springframework.stereotype.Service("workflow_action_ZOA_SIGN_RFCAction") public class ZOA_SIGN_RFCAction extends BaseBean implements Action, EsbServerlessRpcRemoteInterface { @@ -55,50 +58,51 @@ public class ZOA_SIGN_RFCAction extends BaseBean implements Action, EsbServerles String requestid = requestinfo.getRequestid(); RecordSet rs = I18nContextUtil.getBean(RecordSet.class); retstr = new String[2]; - try { - String sapId = ""; - Property[] aproperty = requestinfo.getMainTableInfo().getProperty(); - for (int i = 0; i < aproperty.length; i++) { - String name = aproperty[i].getName().toUpperCase(); - String value = Util.null2String(aproperty[i].getValue()); - if (name.equals("BH")) { - sapId = value; - } - } - RecordSetTrans recordsettrans = I18nContextUtil.getBean(RecordSetTrans.class); - recordsettrans.setAutoCommit(false); - JCoFunction jcofunction = destination.getRepository().getFunction("ZOA_SIGN_RFC"); - if (jcofunction == null) { - logger_43f5aff5.info(String.valueOf("ZOA_SIGN_RFC not found in SAP.")); - retstr[0] = "E"; - retstr[1] = "没找到SAP的ZOA_SIGN_RFC函数"; - } else { - jcofunction.getImportParameterList().setValue("ID", sapId); - logger_43f5aff5.info(String.valueOf("开始调用ZOA_SIGN_RFC函数")); - jcofunction.execute(destination); - retstr[0] = jcofunction.getExportParameterList().getValue("E_STATUS").toString(); - retstr[1] = jcofunction.getExportParameterList().getValue("E_MESSAGE").toString(); - logger_43f5aff5.info(String.valueOf("调用ZOA_SIGN_RFC函数成功：" + retstr[0] + "," + retstr[1])); - } - String sql = "update " + tablename + " set status= '" + retstr[0] + "',message= cast(message as varchar(8000)) +'," + retstr[1] + "' where requestId =" + requestid; - String poolname_pq = CONN_TYPE.workflow.getType(); - // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - rs.executeSql(sql, poolname_pq); - if (!"S".equals(retstr[0])) { - requestinfo.getRequestManager().setMessageid("ERROR"); - requestinfo.getRequestManager().setMessagecontent("SAP返回错误信息：" + retstr[1]); - return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager())); - } - } catch (Exception e) { - logger_43f5aff5.info(String.valueOf("调用ZOA_SIGN_RFC解冻出错：" + e.toString())); - 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; - String poolname = CONN_TYPE.workflow.getType(); - // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - rs.executeSql(sql, poolname); - return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager())); - } + //TODO custom 不启用 +// try { +// String sapId = ""; +// Property[] aproperty = requestinfo.getMainTableInfo().getProperty(); +// for (int i = 0; i < aproperty.length; i++) { +// String name = aproperty[i].getName().toUpperCase(); +// String value = Util.null2String(aproperty[i].getValue()); +// if (name.equals("BH")) { +// sapId = value; +// } +// } +// RecordSetTrans recordsettrans = I18nContextUtil.getBean(RecordSetTrans.class); +// recordsettrans.setAutoCommit(false); +// JCoFunction jcofunction = destination.getRepository().getFunction("ZOA_SIGN_RFC"); +// if (jcofunction == null) { +// logger_43f5aff5.info(String.valueOf("ZOA_SIGN_RFC not found in SAP.")); +// retstr[0] = "E"; +// retstr[1] = "没找到SAP的ZOA_SIGN_RFC函数"; +// } else { +// jcofunction.getImportParameterList().setValue("ID", sapId); +// logger_43f5aff5.info(String.valueOf("开始调用ZOA_SIGN_RFC函数")); +// jcofunction.execute(destination); +// retstr[0] = jcofunction.getExportParameterList().getValue("E_STATUS").toString(); +// retstr[1] = jcofunction.getExportParameterList().getValue("E_MESSAGE").toString(); +// logger_43f5aff5.info(String.valueOf("调用ZOA_SIGN_RFC函数成功：" + retstr[0] + "," + retstr[1])); +// } +// String sql = "update " + tablename + " set status= '" + retstr[0] + "',message= cast(message as varchar(8000)) +'," + retstr[1] + "' where requestId =" + requestid; +// String poolname_pq = CONN_TYPE.workflow.getType(); +// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 +// rs.executeSql(sql, poolname_pq); +// if (!"S".equals(retstr[0])) { +// requestinfo.getRequestManager().setMessageid("ERROR"); +// requestinfo.getRequestManager().setMessagecontent("SAP返回错误信息：" + retstr[1]); +// return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager())); +// } +// } catch (Exception e) { +// logger_43f5aff5.info(String.valueOf("调用ZOA_SIGN_RFC解冻出错：" + e.toString())); +// 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; +// String poolname = CONN_TYPE.workflow.getType(); +// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 +// rs.executeSql(sql, poolname); +// return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager())); +// } return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager())); } catch (Exception e) { e.printStackTrace(); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_SL_GWCC_Action.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_SL_GWCC_Action.java index 56939b0..a64cef2 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_SL_GWCC_Action.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_SL_GWCC_Action.java @@ -542,7 +542,6 @@ public class ZOA_SL_GWCC_Action extends BaseBean implements Action, EsbServerles boolean b1 = rs.executeSql(sql3, poolname_ym); logger_f5224b91.info("sql3 = " + sql3); logger_f5224b91.info("添加 = " + b1); - logger_f5224b91.info("b -----"+ b1); if (applyEmpNum.length() < 10) { // 经办人工号 applyEmpNum = errandEmpNum; 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 e01810a..c26a5b4 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 @@ -23,6 +23,9 @@ import com.weaver.verupgrade.general.Util; import com.weaver.verupgrade.soa.workflow.request.Property; import com.weaver.verupgrade.interfaces.workflow.action.Action; + + + @org.springframework.stereotype.Service("workflow_action_ZOA_STATUS_RFCAction") public class ZOA_STATUS_RFCAction extends BaseBean implements Action, EsbServerlessRpcRemoteInterface { @@ -60,54 +63,55 @@ public class ZOA_STATUS_RFCAction extends BaseBean implements Action, EsbServerl String requestid = requestinfo.getRequestid(); RecordSet rs = I18nContextUtil.getBean(RecordSet.class); retstr = new String[2]; - try { - String sapId = ""; - Property[] aproperty = requestinfo.getMainTableInfo().getProperty(); - for (int i = 0; i < aproperty.length; i++) { - String name = aproperty[i].getName().toUpperCase(); - String value = Util.null2String(aproperty[i].getValue()); - if (name.equals("BH")) { - sapId = value; - } - } - RecordSetTrans recordsettrans = I18nContextUtil.getBean(RecordSetTrans.class); - recordsettrans.setAutoCommit(false); - JCoFunction jcofunction = destination.getRepository().getFunction("ZOA_STATUS_RFC"); - if (jcofunction == null) { - logger_2bfe536a.info(String.valueOf("ZOA_STATUS_RFC not found in SAP.")); - retstr[0] = "E"; - retstr[1] = "没找到SAP的ZOA_STATUS_RFC函数"; - } else { - jcofunction.getImportParameterList().setValue("ID", sapId); - logger_2bfe536a.info(String.valueOf("开始调用ZOA_STATUS_RFC函数")); - jcofunction.execute(destination); - retstr[0] = jcofunction.getExportParameterList().getValue("E_STATUS").toString(); - retstr[1] = jcofunction.getExportParameterList().getValue("E_MESSAGE").toString(); - logger_2bfe536a.info(String.valueOf("调用ZOA_STATUS_RFC函数成功：" + retstr[0] + "," + retstr[1])); - } - String sql = "update e10_core_business.dbo." + tablename + " set status= '" + retstr[0] + "',message= cast(message as varchar(8000)) +'," + retstr[1] + "' where id =" + requestid; - logger_2bfe536a.info("sql -----"+ sql); - String poolname_vx = CONN_TYPE.workflow.getType(); - // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - 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]); - return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager())); - } - } catch (Exception e) { - logger_2bfe536a.info(String.valueOf("调用ZOA_STATUS_RFC更新审批不通过状态出错：" + e.toString())); - requestinfo.getRequestManager().setMessageid("ERROR"); - requestinfo.getRequestManager().setMessagecontent("调用SAP接口出错：" + e.getMessage()); - String sql = "update e10_core_business.dbo." + tablename + " set status= '" + retstr[0] + "',message= cast(message as varchar(8000)) +'," + retstr[1] + "' where id =" + requestid; - logger_2bfe536a.info("sql2 -----"+ sql); - String poolname = CONN_TYPE.workflow.getType(); - // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - boolean b = rs.executeSql(sql, poolname); - logger_2bfe536a.info("b2 -----"+ b); - return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager())); - } + //TODO custom 不启用 +// try { +// String sapId = ""; +// Property[] aproperty = requestinfo.getMainTableInfo().getProperty(); +// for (int i = 0; i < aproperty.length; i++) { +// String name = aproperty[i].getName().toUpperCase(); +// String value = Util.null2String(aproperty[i].getValue()); +// if (name.equals("BH")) { +// sapId = value; +// } +// } +// RecordSetTrans recordsettrans = I18nContextUtil.getBean(RecordSetTrans.class); +// recordsettrans.setAutoCommit(false); +// JCoFunction jcofunction = destination.getRepository().getFunction("ZOA_STATUS_RFC"); +// if (jcofunction == null) { +// logger_2bfe536a.info(String.valueOf("ZOA_STATUS_RFC not found in SAP.")); +// retstr[0] = "E"; +// retstr[1] = "没找到SAP的ZOA_STATUS_RFC函数"; +// } else { +// jcofunction.getImportParameterList().setValue("ID", sapId); +// logger_2bfe536a.info(String.valueOf("开始调用ZOA_STATUS_RFC函数")); +// jcofunction.execute(destination); +// retstr[0] = jcofunction.getExportParameterList().getValue("E_STATUS").toString(); +// retstr[1] = jcofunction.getExportParameterList().getValue("E_MESSAGE").toString(); +// logger_2bfe536a.info(String.valueOf("调用ZOA_STATUS_RFC函数成功：" + retstr[0] + "," + retstr[1])); +// } +// String sql = "update e10_core_business.dbo." + tablename + " set status= '" + retstr[0] + "',message= cast(message as varchar(8000)) +'," + retstr[1] + "' where id =" + requestid; +// logger_2bfe536a.info("sql -----"+ sql); +// String poolname_vx = CONN_TYPE.workflow.getType(); +// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 +// 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]); +// return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager())); +// } +// } catch (Exception e) { +// logger_2bfe536a.info(String.valueOf("调用ZOA_STATUS_RFC更新审批不通过状态出错：" + e.toString())); +// requestinfo.getRequestManager().setMessageid("ERROR"); +// requestinfo.getRequestManager().setMessagecontent("调用SAP接口出错：" + e.getMessage()); +// String sql = "update e10_core_business.dbo." + tablename + " set status= '" + retstr[0] + "',message= cast(message as varchar(8000)) +'," + retstr[1] + "' where id =" + requestid; +// logger_2bfe536a.info("sql2 -----"+ sql); +// String poolname = CONN_TYPE.workflow.getType(); +// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 +// 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())); } catch (Exception e) { e.printStackTrace(); 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 b79c723..2857b61 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 @@ -71,7 +71,8 @@ public class ZSR_PUR_INFO_OEM_Action extends BaseBean implements Action, EsbServ logger_adc1e038.info("sql -----"+ sql); String poolname = CONN_TYPE.workflow.getType(); // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 - rs.executeSql(sql, poolname); + boolean b1 = rs.executeSql(sql, poolname); + logger_adc1e038.info("sql flag1-----"+ b1); if (rs.next()) { mxcount = rs.getInt("mxcount"); logger_adc1e038.info("mxcount -----"+ mxcount);