diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_FICO_COC_CREATIONAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_FICO_COC_CREATIONAction.java index 7d400f4..b2b1d95 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_FICO_COC_CREATIONAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_FICO_COC_CREATIONAction.java @@ -6,10 +6,16 @@ package com.weaver.seconddev.interfaces.workflow.action; import java.util.HashMap; import java.util.Map; + +import com.sap.conn.jco.JCoDestination; +import com.sap.conn.jco.JCoFunction; +import com.sap.conn.jco.JCoStructure; import com.weaver.common.i18n.tool.util.I18nContextUtil; import com.weaver.verupgrade.conn.CONN_TYPE; import java.lang.*; import java.util.*; + +import com.weaver.verupgrade.conn.RecordSetTrans; import com.weaver.verupgrade.workflow.request.RequestManager; import com.weaver.esb.api.rpc.EsbServerlessRpcRemoteInterface; import com.weaver.common.base.entity.result.WeaResult; @@ -60,12 +66,10 @@ public class ZOA_FICO_COC_CREATIONAction extends BaseBean implements Action, Esb String[] returnStr = null; if ("0".equals(sqyw)) { // 新增 - ZOA_FICO_COC_CREATION creation = new ZOA_FICO_COC_CREATION(); - returnStr = creation.Getexecute(map); + returnStr = Getexecute(map); } else if ("1".equals(sqyw)) { // 修改 - ZOA_FICO_COC_CHANGE change = new ZOA_FICO_COC_CHANGE(); - returnStr = change.Getexecute(map); + returnStr = Getexecute(map); } if (returnStr != null && returnStr.length > 0) { String e_istat = String.valueOf(returnStr[0]); @@ -87,7 +91,7 @@ public class ZOA_FICO_COC_CREATIONAction extends BaseBean implements Action, Esb return WeaResult.fail(500, "执行异常", getResultMapForAction(weaverResultMap, "result", "调用接口返回信息为空", requestinfo.getRequestManager())); } } catch (Exception exception) { - logger_8236b79b.info(String.valueOf("ZOA_FICO_COC_CREATIONAction error:" + exception.getMessage())); + logger_8236b79b.error("e--",exception); requestinfo.getRequestManager().setMessageid("ERROR"); requestinfo.getRequestManager().setMessagecontent(exception.getMessage()); return WeaResult.fail(500, "执行异常", getResultMapForAction(weaverResultMap, "result", exception.getMessage(), requestinfo.getRequestManager())); @@ -114,4 +118,58 @@ public class ZOA_FICO_COC_CREATIONAction extends BaseBean implements Action, Esb } return map; } + + public String[] Getexecute(Map map) { + String[] retstr = new String[3]; + JCoDestination destination = SAPConn.getJCoDestination();; + try { + logger_8236b79b.info("map--" + map); + RecordSetTrans recordsettrans = I18nContextUtil.getBean(RecordSetTrans.class); + recordsettrans.setAutoCommit(false); + JCoFunction jcofunction = destination.getRepository().getFunction("ZOA_FICO_ANLA_CHANGE"); + if (jcofunction == null) { + System.out.println("ZOA_FICO_ANLA_CHANGE not found in SAP."); + retstr[2] = "ZOA_FICO_ANLA_CHANGE not found in SAP."; + } else { + JCoStructure stru = jcofunction.getImportParameterList().getStructure("I_INPUT"); + // 资产描述 + stru.setValue("TXT50", map.get("ZCMSGH")); + // 附加资产描述 + stru.setValue("TXA50", map.get("FJZCMSGH")); + // 主资产号 + stru.setValue("ANLN1", map.get("ZCBHXZ")); + // 资产主号说明 + stru.setValue("ANLHTXT", map.get("ZCBHSMGH")); + // 序列号 + stru.setValue("SERNR", map.get("XLHGH")); + // 存货号 + stru.setValue("INVNR", map.get("CHHGH")); + // 成本中心 + stru.setValue("KOSTL", map.get("SYCBZXGH")); + // 成本中心对资产负责 + stru.setValue("KOSTLV", map.get("GLCBZXGH")); + // 内部订单 + stru.setValue("CAUFN", map.get("NBDDGH")); + // 工厂 + stru.setValue("WERKS", map.get("GCGH")); + logger_8236b79b.info(String.valueOf("ZOA_FICO_ANLA_CHANGE--工厂改后：" + map.get("GCGH"))); + // 房间 + stru.setValue("RAUMN", map.get("ZRRGH")); + // 公司代码 + stru.setValue("BUKR", map.get("GS")); + jcofunction.getImportParameterList().setValue("I_INPUT", stru); + try { + jcofunction.execute(destination); + retstr[0] = jcofunction.getExportParameterList().getValue("E_ISTAT").toString(); + retstr[1] = jcofunction.getExportParameterList().getValue("E_MESSAGE").toString(); + } catch (Exception exception1) { + retstr[2] = exception1.toString(); + } + } + return retstr; + } catch (Exception exception) { + retstr[2] = exception.getMessage(); + } + return retstr; + } } diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_SD_CREDIT_HANDLE_QUERYAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_SD_CREDIT_HANDLE_QUERYAction.java index f7d3761..ba3dfa0 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_SD_CREDIT_HANDLE_QUERYAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_SD_CREDIT_HANDLE_QUERYAction.java @@ -34,6 +34,7 @@ public class ZOA_SD_CREDIT_HANDLE_QUERYAction extends BaseBean implements Action private static final Logger logger_270bcd1 = LoggerFactory.getLogger(ZOA_SD_CREDIT_HANDLE_QUERYAction.class); public WeaResult> execute(Map requestInfoMap) { + logger_270bcd1.info("ZOA_SD_CREDIT_HANDLE_QUERYAction 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))); @@ -102,7 +103,7 @@ public class ZOA_SD_CREDIT_HANDLE_QUERYAction extends BaseBean implements Action String wfid = request.getWorkflowid(); // tablename = unit.getTablename(wfid); tablename = request.getRequestManager().getBillTableName(); - String logsql = "update " + tablename + " set sta ='" + sta + "', meg = '" + meg + "' where requestId = " + requestId; + String logsql = "update e10_core_business.dbo." + tablename + " set sta ='" + sta + "', meg = '" + meg + "' where id = " + requestId; logger_270bcd1.info(String.valueOf("logsql:" + logsql)); String poolname = CONN_TYPE.workflow.getType(); // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 @@ -111,16 +112,17 @@ public class ZOA_SD_CREDIT_HANDLE_QUERYAction extends BaseBean implements Action if (!sta.equals("S")) { request.getRequestManager().setMessageid("100001"); request.getRequestManager().setMessagecontent(meg); + return WeaResult.fail(500, "执行异常", getResultMapForAction(weaverResultMap, "result", "", request.getRequestManager())); } System.out.println(meg); } catch (Exception e) { - System.err.println(e.toString()); - logger_270bcd1.info(String.valueOf("调用接口报错 " + e.toString())); + logger_270bcd1.error("调用接口报错-- " ,e); + return WeaResult.fail(500, "执行异常", getResultMapForAction(weaverResultMap, "result", e.getMessage(), request.getRequestManager())); } return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, request.getRequestManager())); } catch (Exception e) { e.printStackTrace(); - logger_270bcd1.error("ZOA_SD_CREDIT_HANDLE_QUERYAction e: {}", e.getMessage()); + logger_270bcd1.error("ZOA_SD_CREDIT_HANDLE_QUERYAction e: {}", e); return WeaResult.success(getResultMapForAction(weaverResultMap, "result", WeaResult.fail(500, "执行异常", getResultMapForAction(weaverResultMap, "result", e.getMessage(), request.getRequestManager())), request.getRequestManager())); } } 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 49f361f..e01810a 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 @@ -85,7 +85,7 @@ public class ZOA_STATUS_RFCAction extends BaseBean implements Action, EsbServerl 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 requestId =" + requestid; + 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方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 @@ -100,7 +100,7 @@ public class ZOA_STATUS_RFCAction extends BaseBean implements Action, EsbServerl 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 requestId =" + requestid; + 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方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源