From a7485c9f9b16ece4f12f0b3f6d6a8c90370f5ae4 Mon Sep 17 00:00:00 2001 From: zhubaomin <zhubaomin> Date: 星期三, 09 四月 2025 16:08:30 +0800 Subject: [PATCH] 灌溉计划详情信息增加取水口命令发布失败数量 --- pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/issue/IssueCtrl.java | 111 +++++++++++++++++++++++++++++++++++++++++++++++++++++-- 1 files changed, 107 insertions(+), 4 deletions(-) diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/issue/IssueCtrl.java b/pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/issue/IssueCtrl.java index 9fb6484..60a4696 100644 --- a/pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/issue/IssueCtrl.java +++ b/pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/issue/IssueCtrl.java @@ -1,19 +1,24 @@ package com.dy.pipIrrApp.issue; +import com.alibaba.fastjson2.JSONObject; import com.dy.common.aop.SsoAop; import com.dy.common.webUtil.BaseResponse; import com.dy.common.webUtil.BaseResponseUtils; +import com.dy.common.webUtil.QueryResultVo; +import com.dy.pipIrrApp.issue.dto.DtoDeleteParam; +import com.dy.pipIrrApp.issue.qo.QoIssueReport; import com.dy.pipIrrGlobal.pojoOp.OpeIssueReport; +import com.dy.pipIrrGlobal.pojoOp.OpeReportReply; +import com.dy.pipIrrGlobal.voOp.VoIssueReport; +import com.dy.pipIrrGlobal.voOp.VoIssueReportReply; import jakarta.validation.Valid; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.transaction.annotation.Transactional; import org.springframework.validation.BindingResult; -import org.springframework.web.bind.annotation.PostMapping; -import org.springframework.web.bind.annotation.RequestBody; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RestController; +import org.springframework.web.bind.annotation.*; +import java.util.List; import java.util.Objects; /** @@ -52,4 +57,102 @@ return BaseResponseUtils.buildSuccess(true) ; } + /** + * 鑾峰彇宸℃鍛橀棶棰樹笂鎶ヨ褰� + * @param vo + * @return + */ + @GetMapping(path = "/getIssueReports") + @SsoAop() + public BaseResponse<QueryResultVo<List<VoIssueReport>>> getIssueReports(QoIssueReport vo) { + try { + //QueryResultVo<List<VoIssueReport_temp>> res = issueSv.getIssueReports(vo); + return BaseResponseUtils.buildSuccess(issueSv.getIssueReports(vo)); + } catch (Exception e) { + log.error("鑾峰彇宸℃鍛橀棶棰樹笂鎶ヨ褰曞紓甯�", e); + return BaseResponseUtils.buildException(e.getMessage()); + } + } + + /** + * 鑾峰彇涓�涓贰妫�鍛橀棶棰樹笂鎶ヨ褰曡鎯� + * @param issueReportId + * @return + */ + @GetMapping(path = "/getOneIssueReport") + @SsoAop() + public BaseResponse<VoIssueReport> getOneIssueReport(@RequestParam("issueReportId") Long issueReportId) { + try { + VoIssueReport issueReport = issueSv.getIssueReportById(issueReportId); + if(issueReport == null) { + return BaseResponseUtils.buildNonExist(); + } + return BaseResponseUtils.buildSuccess(issueReport); + } catch (Exception e) { + log.error("鑾峰彇闂涓婃姤璁板綍璇︽儏寮傚父", e); + return BaseResponseUtils.buildException(e.getMessage()); + } + } + + /** + * 閫昏緫鍒犻櫎宸℃鍛橀棶棰樹笂鎶ワ紝鍒犻櫎鍓嶅厛鍒ゆ柇瑕佸垹闄ょ殑涓婃姤鏄惁瀛樺湪 + * @param po + * @param bindingResult + * @return + */ + @PostMapping(path = "deleteIssueReport") + public BaseResponse<Boolean> deleteIssueReport(@RequestBody @Valid DtoDeleteParam po, BindingResult bindingResult) { + if(bindingResult != null && bindingResult.hasErrors()){ + return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); + } + + String result = issueSv.deleteIssueReport(po); + if(!result.equals("success")) { + return BaseResponseUtils.buildErrorMsg(result); + } + + return BaseResponseUtils.buildSuccess(); + + } + + /** + * 鍥炲宸℃鍛橀棶棰樹笂鎶� + * @param po + * @param bindingResult + * @return + */ + @PostMapping(path = "replyReport") + @Transactional(rollbackFor = Exception.class) + public BaseResponse<Boolean> replyReport(@RequestBody @Valid OpeReportReply po, BindingResult bindingResult) { + if(bindingResult != null && bindingResult.hasErrors()){ + return BaseResponseUtils.buildErrorMsg(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); + } + if (issueSv.getReportReply(po.getReportId()).get("code").equals("0001")){ + return BaseResponseUtils.buildErrorMsg("璇ラ棶棰樹笂鎶ュ凡鍥炲锛岃鍕块噸澶嶅洖澶�"); + } + String result = issueSv.replyReport(po); + if(!result.equals("sucess")) { + return BaseResponseUtils.buildErrorMsg(result); + } + + return BaseResponseUtils.buildSuccess() ; + } + + /** + * 鏍规嵁闂涓婃姤ID鑾峰彇涓婃姤鍥炲淇℃伅 + * @param reportId + * @return + */ + @GetMapping(path = "/getReportReply") + public BaseResponse<VoIssueReportReply> getReportReply(@RequestParam("reportId") Long reportId) { + + JSONObject result = issueSv.getReportReply(reportId); + if(!result.get("code").equals("0001")) { + return BaseResponseUtils.buildErrorMsg(result.get("msg").toString()); + } + + return BaseResponseUtils.buildSuccess(result.get("data")); + + } + } -- Gitblit v1.8.0