From 5b719d94b4fbe50526800a0ded49a9084ee48873 Mon Sep 17 00:00:00 2001 From: wuzeyu <1223318623@qq.com> Date: 星期三, 24 七月 2024 09:24:34 +0800 Subject: [PATCH] 农户日用水量查询(历史) 农户日用水量查询(最新) --- pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/valve/ValveCtrl.java | 186 +++++++++++++++++++++++----------------------- 1 files changed, 94 insertions(+), 92 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 279d91c..06f622c 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 @@ -116,9 +116,11 @@ if(vc == null) { return BaseResponseUtils.buildErrorMsg(RemoteResultCode.PLEASE_SELECT_A_VC.getMessage()); } - if(vc.getInUse() == 1) { - return BaseResponseUtils.buildErrorMsg(RemoteResultCode.IN_USE_VC_CANNOT_OPEN_VALVE.getMessage()); - } + + //鍢夊唱鍏抽」鐩櫄鎷熷崱涓嶆墸璐癸紝涓嶅仛浣跨敤涓垽鏂� + //if(vc.getInUse() == 1) { + // return BaseResponseUtils.buildErrorMsg(RemoteResultCode.IN_USE_VC_CANNOT_OPEN_VALVE.getMessage()); + //} // 鑾峰彇姘翠环 Double waterPrice = commandSv.getPrice(); @@ -145,7 +147,7 @@ ComCd92_A2Vo param = new ComCd92_A2Vo(); param.controllerType = controllerType; param.projectNo = projectNo; - param.icCardNo = vc.getVcNum(); + param.icCardNo = vc.getVcNum().toString(); param.waterRemain = 0.0; param.moneyRemain = vc.getMoney(); param.waterPrice = waterPrice; @@ -176,7 +178,7 @@ // 鍒涘缓瑙嗗浘 Com97Vo param = new Com97Vo() ; - param.icCardNo = vc.getVcNum(); + param.icCardNo = vc.getVcNum().toString(); param.moneyRemain = vc.getMoney(); param.waterPrice = waterPrice; param.orderNo = orderNo; @@ -484,91 +486,91 @@ * @param bindingResult * @return */ - @PostMapping(path = "usability", consumes = MediaType.APPLICATION_JSON_VALUE) - @Transactional(rollbackFor = Exception.class) - @SsoAop() - public BaseResponse<Boolean> usability(@RequestBody @Valid Usability usability, BindingResult bindingResult) { - if(bindingResult != null && bindingResult.hasErrors()){ - return BaseResponseUtils.buildErrorMsg(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); - } - - Long intakeId = usability.getIntakeId(); - Boolean valid = usability.getValid(); - Long operator = usability.getOperator(); - Long comId = idLongGenerator.generate(); - - // 鑾峰彇绯荤粺鍙傛暟 - if(!setuped) { - setUp(); - } - - // 鍙栨按鍙D鎹㈤榾鎺у櫒鍦板潃鍙婇�氳鍗忚 - JSONObject job_rtu = getRtu(intakeId, null); - if(job_rtu == null) { - return BaseResponseUtils.buildErrorMsg(RemoteResultCode.RTU_NOT_EXIST.getMessage()); - } - String rtuAddr = job_rtu.getString("rtuAddr"); - String protocol = job_rtu.getString("protocol"); - - String commandCode = null; - if(protocol.equals("p206V202404")) { - if(valid) { - // 鑾峰彇鍔熻兘鐮� - commandCode = CodeV202404.cd_30; - - // 鍒涘缓瑙嗗浘 - ComCd31Vo param = new ComCd31Vo(); - param.controllerType = controllerType; - param.projectNo = projectNo; - param.valid = true; - - /** - * 鏋勯�犲懡浠ゃ�佸彂閫佸懡浠ゅ苟澶勭悊璇锋眰缁撴灉鍙婃墽琛岀粨鏋� - * 1 鍑嗗鍙傛暟 - * 2 璋冪敤鍏叡鏂规硶 - */ - Param myParam = new Param(); - myParam.setComId(comId); - myParam.setCommandCode(commandCode); - myParam.setCommandName(CodeV202404.getCodeName(commandCode)); - myParam.setIntakeId(intakeId); - myParam.setRtuAddr(rtuAddr); - myParam.setProtocol(protocol); - myParam.setParam(param); - myParam.setRtuResultSendWebUrl(rtuCallbackUrl_rm); - myParam.setOperator(operator); - return dealWithCommandResult(myParam); - }else { - // 鑾峰彇鍔熻兘鐮� - commandCode = CodeV202404.cd_31; - - // 鍒涘缓瑙嗗浘 - ComCd31Vo param = new ComCd31Vo(); - param.controllerType = controllerType; - param.projectNo = projectNo; - param.valid = false; - - /** - * 鏋勯�犲懡浠ゃ�佸彂閫佸懡浠ゅ苟澶勭悊璇锋眰缁撴灉鍙婃墽琛岀粨鏋� - * 1 鍑嗗鍙傛暟 - * 2 璋冪敤鍏叡鏂规硶 - */ - Param myParam = new Param(); - myParam.setComId(comId); - myParam.setCommandCode(commandCode); - myParam.setCommandName(CodeV202404.getCodeName(commandCode)); - myParam.setIntakeId(intakeId); - myParam.setRtuAddr(rtuAddr); - myParam.setProtocol(protocol); - myParam.setParam(param); - myParam.setRtuResultSendWebUrl(rtuCallbackUrl_rm); - myParam.setOperator(operator); - return dealWithCommandResult(myParam); - } - } else if(protocol.equals("p206V1_0_1")) { - return BaseResponseUtils.buildErrorMsg(RemoteResultCode.THE_DEVICE_DOES_NOT_HAVE_THIS_FUNCTION.getMessage()); - } else { - return BaseResponseUtils.buildErrorMsg("绯荤粺鏆備笉鏀寔璇ュ崗璁�"); - } - } + //@PostMapping(path = "usability", consumes = MediaType.APPLICATION_JSON_VALUE) + //@Transactional(rollbackFor = Exception.class) + //@SsoAop() + //public BaseResponse<Boolean> usability(@RequestBody @Valid Usability usability, BindingResult bindingResult) { + // if(bindingResult != null && bindingResult.hasErrors()){ + // return BaseResponseUtils.buildErrorMsg(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); + // } + // + // Long intakeId = usability.getIntakeId(); + // Boolean valid = usability.getValid(); + // Long operator = usability.getOperator(); + // Long comId = idLongGenerator.generate(); + // + // // 鑾峰彇绯荤粺鍙傛暟 + // if(!setuped) { + // setUp(); + // } + // + // // 鍙栨按鍙D鎹㈤榾鎺у櫒鍦板潃鍙婇�氳鍗忚 + // JSONObject job_rtu = getRtu(intakeId, null); + // if(job_rtu == null) { + // return BaseResponseUtils.buildErrorMsg(RemoteResultCode.RTU_NOT_EXIST.getMessage()); + // } + // String rtuAddr = job_rtu.getString("rtuAddr"); + // String protocol = job_rtu.getString("protocol"); + // + // String commandCode = null; + // if(protocol.equals("p206V202404")) { + // if(valid) { + // // 鑾峰彇鍔熻兘鐮� + // commandCode = CodeV202404.cd_30; + // + // // 鍒涘缓瑙嗗浘 + // ComCd31Vo param = new ComCd31Vo(); + // param.controllerType = controllerType; + // param.projectNo = projectNo; + // param.valid = true; + // + // /** + // * 鏋勯�犲懡浠ゃ�佸彂閫佸懡浠ゅ苟澶勭悊璇锋眰缁撴灉鍙婃墽琛岀粨鏋� + // * 1 鍑嗗鍙傛暟 + // * 2 璋冪敤鍏叡鏂规硶 + // */ + // Param myParam = new Param(); + // myParam.setComId(comId); + // myParam.setCommandCode(commandCode); + // myParam.setCommandName(CodeV202404.getCodeName(commandCode)); + // myParam.setIntakeId(intakeId); + // myParam.setRtuAddr(rtuAddr); + // myParam.setProtocol(protocol); + // myParam.setParam(param); + // myParam.setRtuResultSendWebUrl(rtuCallbackUrl_rm); + // myParam.setOperator(operator); + // return dealWithCommandResult(myParam); + // }else { + // // 鑾峰彇鍔熻兘鐮� + // commandCode = CodeV202404.cd_31; + // + // // 鍒涘缓瑙嗗浘 + // ComCd31Vo param = new ComCd31Vo(); + // param.controllerType = controllerType; + // param.projectNo = projectNo; + // param.valid = false; + // + // /** + // * 鏋勯�犲懡浠ゃ�佸彂閫佸懡浠ゅ苟澶勭悊璇锋眰缁撴灉鍙婃墽琛岀粨鏋� + // * 1 鍑嗗鍙傛暟 + // * 2 璋冪敤鍏叡鏂规硶 + // */ + // Param myParam = new Param(); + // myParam.setComId(comId); + // myParam.setCommandCode(commandCode); + // myParam.setCommandName(CodeV202404.getCodeName(commandCode)); + // myParam.setIntakeId(intakeId); + // myParam.setRtuAddr(rtuAddr); + // myParam.setProtocol(protocol); + // myParam.setParam(param); + // myParam.setRtuResultSendWebUrl(rtuCallbackUrl_rm); + // myParam.setOperator(operator); + // return dealWithCommandResult(myParam); + // } + // } else if(protocol.equals("p206V1_0_1")) { + // return BaseResponseUtils.buildErrorMsg(RemoteResultCode.THE_DEVICE_DOES_NOT_HAVE_THIS_FUNCTION.getMessage()); + // } else { + // return BaseResponseUtils.buildErrorMsg("绯荤粺鏆備笉鏀寔璇ュ崗璁�"); + // } + //} } -- Gitblit v1.8.0