rj
/
ht
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

4 files update

Browse Source
webservice
calyrex 5 months ago
parent 627cf4973d
commit 0ed7bb28df
3 changed files with 71 additions and 11 deletions
Show Stats Download Patch File Download Diff File

68
secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_FICO_COC_CREATIONAction.java
Unescape Escape View File

@ -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<String, String> 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;
}
}

10
secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_SD_CREDIT_HANDLE_QUERYAction.java
Unescape Escape View File

@ -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<Map<String, Object>> execute(Map<String, Object> requestInfoMap) {
logger_270bcd1.info("ZOA_SD_CREDIT_HANDLE_QUERYAction start");
Map<String, Object> 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()));
}
}

4
secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_STATUS_RFCAction.java
Unescape Escape View File

@ -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方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源

Write Preview
Loading…
Cancel
Save