mes/nalinv-int
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix（物料同步接口）：调整job

Browse Source 
refs：#43700

(cherry picked from commit 854a9ce4de)
This commit is contained in:
liaohechuan 2024-11-15 20:59:19 +08:00 committed by 彭枝刚
parent 61ba04aa46
commit c2a58aac64
1 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
int-core/src/main/java/com/foreverwin/iep/integration/handler/def/job/SapMaterielReceiveForWorkJob.java
View File

@ -32,7 +32,7 @@ public class SapMaterielReceiveForWorkJob {
// messageContent传参对象
JSONObject jsonInvokeRequest = new JSONObject();
// 需要多包一层且些许字段需要大写，否则不会存日志
InvokeRequest invokeRequestNew = new InvokeRequest();
InvokeRequest invokeRequest = new InvokeRequest();
try {
String site = null;
@ -52,11 +52,11 @@ public class SapMaterielReceiveForWorkJob {
jsonInvokeRequest.put("SENDER", "ERP");
jsonInvokeRequest.put("SITE", site);
jsonInvokeRequest.put("MESSAGE_ID", "SAP_MATERIEL_RECEIVE");
invokeRequestNew.setTransSid(StrUtil.uuid());
invokeRequestNew.setTransTime(nowTime);
invokeRequestNew.setFromSystem("ERP");
invokeRequestNew.setSite(site);
invokeRequestNew.setMessageId("SAP_MATERIEL_RECEIVE");
invokeRequest.setTransSid(StrUtil.uuid());
invokeRequest.setTransTime(nowTime);
invokeRequest.setFromSystem("ERP");
invokeRequest.setSite(site);
invokeRequest.setMessageId("SAP_MATERIEL_RECEIVE");
JSONObject jsonObject = new JSONObject();
jsonObject.put("RFC_FUNCTION", "ZPP_MES_MATNR_GET");
JSONObject conTextJsonObject = new JSONObject();
@ -86,15 +86,15 @@ public class SapMaterielReceiveForWorkJob {
jsonInvokeRequest.put("keyValue", String.valueOf(System.currentTimeMillis()));
jsonInvokeRequest.put("RECEIVER", "MES");
jsonInvokeRequest.put("retry", false);
invokeRequestNew.setStart(nowTime);
invokeRequestNew.setKeyValue(String.valueOf(System.currentTimeMillis()));
invokeRequestNew.setToSystem("IEP");
invokeRequestNew.setRetry(false);
invokeRequest.setStart(nowTime);
invokeRequest.setKeyValue(String.valueOf(System.currentTimeMillis()));
invokeRequest.setToSystem("IEP");
invokeRequest.setRetry(false);
}
TenantContextHolder.setTenantId(site);
invokeRequestNew.setMessageContent(JsonUtils.converToString(jsonInvokeRequest));
handlerService.call(invokeRequestNew);
invokeRequest.setMessageContent(JsonUtils.converToString(jsonInvokeRequest));
handlerService.call(invokeRequest);
} catch (Exception e) {
XxlJobHelper.handleFail("物料同步失败：" + e);
return ReturnT.FAIL;