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