From f4921197a4d6d5c58da855fb58870cb6668d7851 Mon Sep 17 00:00:00 2001
From: liurunyu <lry9898@163.com>
Date: 星期一, 22 七月 2024 16:25:14 +0800
Subject: [PATCH] Merge branch 'master' of http://8.140.179.55:20000/r/pipIrr-SV
---
pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/command/ComSupport.java | 38 ++++++++++----------------------------
1 files changed, 10 insertions(+), 28 deletions(-)
diff --git a/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/command/ComSupport.java b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/command/ComSupport.java
index f774726..95daca2 100644
--- a/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/command/ComSupport.java
+++ b/pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/command/ComSupport.java
@@ -178,8 +178,9 @@
com.type = commandTypeOuter;
com.rtuResultSendWebUrl = rtuResultSendWebUrl;
- com.param = param;
-
+ if(param != null) {
+ com.param = param;
+ }
return com;
}
@@ -190,7 +191,7 @@
* @return
*/
protected BaseResponse<Data> dealWithCallBack(Long comId, Command com) {
- CompletableFuture<Data> feature = new CompletableFuture<>();
+ CompletableFuture<JSONObject> feature = new CompletableFuture<>();
features.put(comId, feature);
try {
// 鍙戦�佸懡浠�
@@ -202,9 +203,10 @@
return BaseResponseUtils.buildErrorMsg(job_param.getString("message"));
}
- Data resultData = feature.get(180, TimeUnit.SECONDS);
+ JSONObject resultData = feature.get(180, TimeUnit.SECONDS);
features.remove(comId);
- Long commandId = Long.parseLong(resultData.getCommandId());
+
+ Long commandId = resultData.getLong("commandId");
if (commandId.equals(comId)) {
return BaseResponseUtils.buildSuccess(resultData);
} else {
@@ -283,7 +285,8 @@
rmCommandHistory.setComId(comId);
rmCommandHistory.setResult((byte) 0);
rmCommandHistoryMapper.updateByPrimaryKeySelective(rmCommandHistory);
- return BaseResponseUtils.buildErrorMsg(response_CallBack.getContent().toString());
+ //return BaseResponseUtils.buildErrorMsg(response_CallBack.getContent().toString());
+ return BaseResponseUtils.buildErrorMsg(response_CallBack.getMsg());
}
// 鍥炶皟瓒呮椂
@@ -301,27 +304,7 @@
return BaseResponseUtils.buildErrorMsg(CommandResultCode.GET_RESULT_IN_ONE_MINUTE.getMessage());
}
- // 鍥炶皟鎴愬姛锛屽啀鍒ゆ柇鎵ц鏄惁鎴愬姛
- JSONObject job_content = (JSONObject) JSON.toJSON(response_CallBack.getContent());
- JSONObject job_subData = (JSONObject) job_content.getJSONObject("subData").getJSONObject("subData");
- Boolean dealResult = job_subData.getBoolean("success");
- if (!dealResult) {
- /**
- * 鎵ц澶辫触
- * 鏇存柊鎵ц缁撴灉銆佽繑鍥炵粨鏋滄椂闂淬�佺粨鏋滃唴瀹�
- */
- rmCommandHistory = new RmCommandHistory();
- rmCommandHistory.setComId(comId);
- rmCommandHistory.setResult((byte) 0);
- rmCommandHistory.setResultTime(new Date());
- //rmCommandHistory.setResultText((JSONObject)JSON.toJSON(response_CallBack.getContent()));
- rmCommandHistory.setResultText(response_CallBack.getContent().toString());
- rmCommandHistoryMapper.updateByPrimaryKeySelective(rmCommandHistory);
- return BaseResponseUtils.buildErrorMsg(response_CallBack.getContent().toString());
- }
-
/**
- * 鎵ц鎴愬姛
* 濡傛灉鏄紑鍏抽榾锛氭洿鏀硅櫄鎷熷崱鐘舵�侊細鏄惁浣跨敤涓�佹渶鍚庢搷浣溿�佹渶鍚庢搷浣滄椂闂�
* 鏇存柊鎵ц缁撴灉銆佽繑鍥炵粨鏋滄椂闂淬�佺粨鏋滃唴瀹�
* 杩斿洖鍥炶皟鍐呭
@@ -340,8 +323,7 @@
}
// 鍥炶皟杩斿洖鐨勫唴瀹癸紝鍥炶皟缁撴灉鍐欏叆鍛戒护鏃ュ織琛ㄧ殑浠诲姟鐢变腑闂翠欢瀹屾垚
- Data myData = (Data) response_CallBack.getContent();
- return BaseResponseUtils.buildSuccess(myData);
+ return response_CallBack;
}
}
--
Gitblit v1.8.0