From 818e68817af88d2616f8b61dd5a428d58af40838 Mon Sep 17 00:00:00 2001
From: Administrator <zhubaomin>
Date: 星期五, 07 六月 2024 11:39:40 +0800
Subject: [PATCH] 2024-06-07 朱宝民 开关阀接口回调超时(平台及小程序)改为按执行失败处理

---
 pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/valve/ValveCtrl.java |   97 +++++++++++++++++++++++++++++-------------------
 1 files changed, 59 insertions(+), 38 deletions(-)

diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/valve/ValveCtrl.java b/pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/valve/ValveCtrl.java
index 491cf99..7e7def7 100644
--- a/pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/valve/ValveCtrl.java
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/valve/ValveCtrl.java
@@ -240,25 +240,32 @@
                 // 鍥炶皟瓒呮椂
                 if(response_CallBack.getContent().toString().equals(RemoteResultCode.GET_RESULT_IN_ONE_MINUTE.getMessage())) {
                     /**
-                     * 绯婃帀瓒呮椂锛屾殏鏃惰涓烘墽琛屾垚鍔�
-                     * 鏇存敼铏氭嫙鍗$姸鎬侊細鏄惁浣跨敤涓�佹渶鍚庢搷浣溿�佹渶鍚庢搷浣滄椂闂�
-                     * 杩斿洖寮�闃�闇�瑕佺殑鍙傛暟
+                     * 鍥炶皟瓒呮椂锛屾殏鏃惰涓烘墽琛屽け璐�
+                     * 鍛戒护缃负澶辫触
+                     * 铏氭嫙鍗′緷鏃т繚鎸佷娇鐢ㄤ腑鐨勭姸鎬�
+                     * 涓嶈繑鍥炲叧闃�鍙傛暟
                      */
-                    SeVirtualCard virtualCard = new SeVirtualCard();
-                    virtualCard.setId(vcId);
-                    virtualCard.setInUse((byte) 1);
-                    virtualCard.setLastOperate(LastOperateENUM.OPEN_VALVE.getCode());
-                    virtualCard.setLastOperateTime(new Date());
-                    seVirtualCardMapper.updateByPrimaryKeySelective(virtualCard);
 
-                    JSONObject job_response = new JSONObject();
-                    job_response.put("message", RemoteResultCode.GET_RESULT_IN_ONE_MINUTE.getMessage());
-                    job_response.put("rtuAddr", rtuAddr);
-                    job_response.put("vcNum", vc.getVcNum());
-                    job_response.put("orderNo", orderNo);
-                    //job_response.put("operator", operator);
-                    return BaseResponseUtils.buildSuccess(job_response);
-                    //return BaseResponseUtils.buildSuccess(RemoteResultCode.GET_RESULT_IN_ONE_MINUTE.getMessage());
+                    rmCommandHistory = new RmCommandHistory();
+                    rmCommandHistory.setId(comId);
+                    rmCommandHistory.setResult((byte)0);
+                    commandSv.updateCommandResult(rmCommandHistory);
+
+                    //SeVirtualCard virtualCard = new SeVirtualCard();
+                    //virtualCard.setId(vcId);
+                    //virtualCard.setInUse((byte) 1);
+                    //virtualCard.setLastOperate(LastOperateENUM.OPEN_VALVE.getCode());
+                    //virtualCard.setLastOperateTime(new Date());
+                    //seVirtualCardMapper.updateByPrimaryKeySelective(virtualCard);
+
+                    //JSONObject job_response = new JSONObject();
+                    //job_response.put("message", RemoteResultCode.GET_RESULT_IN_ONE_MINUTE.getMessage());
+                    //job_response.put("rtuAddr", rtuAddr);
+                    //job_response.put("vcNum", vc.getVcNum());
+                    //job_response.put("orderNo", orderNo);
+                    //return BaseResponseUtils.buildSuccess(job_response);
+                    return BaseResponseUtils.buildFail(RemoteResultCode.GET_RESULT_IN_ONE_MINUTE.getMessage());
+
                 }
 
                 // 鍥炶皟鎴愬姛锛屽啀鍒ゆ柇鎵ц鏄惁鎴愬姛
@@ -446,17 +453,24 @@
                 // 鍥炶皟瓒呮椂
                 if(response_CallBack.getContent().toString().equals(RemoteResultCode.GET_RESULT_IN_ONE_MINUTE.getMessage())) {
                     /**
-                     * 绯婃帀瓒呮椂锛屾殏鏃惰涓烘墽琛屾垚鍔�
-                     * 鏇存敼铏氭嫙鍗$姸鎬侊細鏄惁浣跨敤涓�佹渶鍚庢搷浣溿�佹渶鍚庢搷浣滄椂闂�
+                     * 鍥炶皟瓒呮椂锛屾殏鏃惰涓烘墽琛屽け璐�
+                     * 鍛戒护缃负澶辫触
+                     * 铏氭嫙鍗′緷鏃т繚鎸佷娇鐢ㄤ腑鐨勭姸鎬�
                      */
-                    Long vcId = seVirtualCardMapper.getVcIdByNum(vcNum);
-                    SeVirtualCard virtualCard = new SeVirtualCard();
-                    virtualCard.setId(vcId);
-                    virtualCard.setInUse((byte) 0);
-                    virtualCard.setLastOperate(LastOperateENUM.OPEN_VALVE.getCode());
-                    virtualCard.setLastOperateTime(new Date());
-                    seVirtualCardMapper.updateByPrimaryKeySelective(virtualCard);
-                    return BaseResponseUtils.buildSuccess(RemoteResultCode.GET_RESULT_IN_ONE_MINUTE.getMessage());
+
+                    rmCommandHistory = new RmCommandHistory();
+                    rmCommandHistory.setId(comId);
+                    rmCommandHistory.setResult((byte)0);
+                    commandSv.updateCommandResult(rmCommandHistory);
+
+                    //Long vcId = seVirtualCardMapper.getVcIdByNum(vcNum);
+                    //SeVirtualCard virtualCard = new SeVirtualCard();
+                    //virtualCard.setId(vcId);
+                    //virtualCard.setInUse((byte) 0);
+                    //virtualCard.setLastOperate(LastOperateENUM.OPEN_VALVE.getCode());
+                    //virtualCard.setLastOperateTime(new Date());
+                    //seVirtualCardMapper.updateByPrimaryKeySelective(virtualCard);
+                    return BaseResponseUtils.buildFail(RemoteResultCode.GET_RESULT_IN_ONE_MINUTE.getMessage());
                 }
 
                 // 鍥炶皟鎴愬姛锛屽啀鍒ゆ柇鎵ц鏄惁鎴愬姛
@@ -514,7 +528,7 @@
 
         VoUnclosedParam voUnclosedParam = commandSv.getUncloseParam(intakeId);
         if(voUnclosedParam == null) {
-            return BaseResponseUtils.buildFail(RemoteResultCode.VALVE_CLOSED.getMessage());
+            return BaseResponseUtils.buildSuccess(RemoteResultCode.VALVE_CLOSED.getMessage());
         }
         String rtuAddr = voUnclosedParam.getRtuAddr();
         String vcNum = voUnclosedParam.getVcNum();
@@ -642,17 +656,24 @@
                 // 鍥炶皟瓒呮椂
                 if(response_CallBack.getContent().toString().equals(RemoteResultCode.GET_RESULT_IN_ONE_MINUTE.getMessage())) {
                     /**
-                     * 绯婃帀瓒呮椂锛屾殏鏃惰涓烘墽琛屾垚鍔�
-                     * 鏇存敼铏氭嫙鍗$姸鎬侊細鏄惁浣跨敤涓�佹渶鍚庢搷浣溿�佹渶鍚庢搷浣滄椂闂�
+                     * 鍥炶皟瓒呮椂锛屾殏鏃惰涓烘墽琛屽け璐�
+                     * 鍛戒护缃负澶辫触
+                     * 铏氭嫙鍗′緷鏃т繚鎸佷娇鐢ㄤ腑鐨勭姸鎬�
                      */
-                    Long vcId = seVirtualCardMapper.getVcIdByNum(vcNum);
-                    SeVirtualCard virtualCard = new SeVirtualCard();
-                    virtualCard.setId(vcId);
-                    virtualCard.setInUse((byte) 0);
-                    virtualCard.setLastOperate(LastOperateENUM.OPEN_VALVE.getCode());
-                    virtualCard.setLastOperateTime(new Date());
-                    seVirtualCardMapper.updateByPrimaryKeySelective(virtualCard);
-                    return BaseResponseUtils.buildSuccess(RemoteResultCode.GET_RESULT_IN_ONE_MINUTE.getMessage());
+
+                    rmCommandHistory = new RmCommandHistory();
+                    rmCommandHistory.setId(comId);
+                    rmCommandHistory.setResult((byte)0);
+                    commandSv.updateCommandResult(rmCommandHistory);
+
+                    //Long vcId = seVirtualCardMapper.getVcIdByNum(vcNum);
+                    //SeVirtualCard virtualCard = new SeVirtualCard();
+                    //virtualCard.setId(vcId);
+                    //virtualCard.setInUse((byte) 0);
+                    //virtualCard.setLastOperate(LastOperateENUM.OPEN_VALVE.getCode());
+                    //virtualCard.setLastOperateTime(new Date());
+                    //seVirtualCardMapper.updateByPrimaryKeySelective(virtualCard);
+                    return BaseResponseUtils.buildFail(RemoteResultCode.GET_RESULT_IN_ONE_MINUTE.getMessage());
                 }
 
                 // 鍥炶皟鎴愬姛锛屽啀鍒ゆ柇鎵ц鏄惁鎴愬姛

--
Gitblit v1.8.0