From e6a9e6f750115579c8cc90d7e6d5bf1eebe79b90 Mon Sep 17 00:00:00 2001
From: zhubaomin <zhubaomin>
Date: 星期二, 05 十一月 2024 15:26:24 +0800
Subject: [PATCH] 获取农户数据去掉重复记录,微信支付的传参、返回值、接口、数据库表金额都以元为单位

---
 pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/issue/IssueCtrl.java |   39 ++++++++++++++++++++++++++++++---------
 1 files changed, 30 insertions(+), 9 deletions(-)

diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/issue/IssueCtrl.java b/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/issue/IssueCtrl.java
index 305f725..925dad6 100644
--- a/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/issue/IssueCtrl.java
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/issue/IssueCtrl.java
@@ -8,6 +8,7 @@
 import com.dy.pipIrrGlobal.pojoSe.SeReportReply;
 import com.dy.pipIrrGlobal.voSe.VoIssueReport;
 import com.dy.pipIrrGlobal.voSe.VoIssueReportReply;
+import com.dy.pipIrrWechat.issue.dto.DtoDeleteParam;
 import com.dy.pipIrrWechat.issue.dto.DtoIssueReport;
 import com.dy.pipIrrWechat.issue.dto.DtoReportReply;
 import com.dy.pipIrrWechat.issue.qo.QoIssueReport;
@@ -96,23 +97,29 @@
     }
 
     /**
-     * 閫昏緫鍒犻櫎鍐滄埛闂涓婃姤
-     * @param issueReportId
+     * 閫昏緫鍒犻櫎鍐滄埛闂涓婃姤锛屽垹闄ゅ墠鍏堝垽鏂鍒犻櫎鐨勪笂鎶ユ槸鍚﹀瓨鍦�
+     * @param po
+     * @param bindingResult
      * @return
      */
     @PostMapping(path = "deleteIssueReport")
-    public BaseResponse<Boolean> deleteIssueReport(@RequestParam("issueReportId") Long issueReportId) {
-        if (issueReportId == null) {
-            return BaseResponseUtils.buildErrorMsg("鏈�夋嫨瑕佸垹闄ょ殑鍐滄埛闂涓婃姤");
+    public BaseResponse<Boolean> deleteIssueReport(@RequestBody @Valid DtoDeleteParam po, BindingResult bindingResult) {
+        if(bindingResult != null && bindingResult.hasErrors()){
+            return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage());
+        }
+
+        // 鏍规嵁涓婃姤ID鍙婂啘鎴稩D鑾峰彇鏈垹闄ょ殑涓婃姤锛屽垹闄や笂鎶ュ垽鏂娇鐢�
+        SeIssueReport seIssueReport = issueSv.getReport(po.getIssueReportId(), po.getClientId());
+        if(seIssueReport == null) {
+            return BaseResponseUtils.buildErrorMsg("鎮ㄨ鍒犻櫎鐨勯棶棰樹笂鎶ヤ笉瀛樺湪");
         }
 
         try {
-            //鍙栨按鍙D
-            Integer recordCount = Optional.ofNullable(issueSv.deleteIssueReport(issueReportId)).orElse(0);
+            Integer recordCount = Optional.ofNullable(issueSv.deleteIssueReport(po.getIssueReportId())).orElse(0);
             if (recordCount == 0) {
                 return BaseResponseUtils.buildErrorMsg("鍐滄埛闂涓婃姤鍒犻櫎澶辫触");
-            } else {
-                return BaseResponseUtils.buildSuccess(true);
+            }else {
+                return BaseResponseUtils.buildSuccess();
             }
         } catch (Exception e) {
             log.error("鍐滄埛闂涓婃姤鍒犻櫎澶辫触", e);
@@ -133,6 +140,7 @@
             return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage());
         }
 
+        // 娣诲姞涓婃姤鍥炲璁板綍
         SeReportReply seReportReply = new SeReportReply();
         seReportReply.setReportId(po.getReportId());
         seReportReply.setReplyContent(po.getReplyContent());
@@ -141,6 +149,15 @@
         Long reportReplyId = issueSv.insertReportReply(seReportReply);
         if(reportReplyId == null) {
             return BaseResponseUtils.buildErrorMsg("鍥炲鍐滄埛闂涓婃姤澶辫触");
+        }
+
+        // 淇敼闂涓婃姤鐘舵�佷负宸插洖澶�
+        SeIssueReport seIssueReport = new SeIssueReport();
+        seIssueReport.setId(po.getReportId());
+        seIssueReport.setState((byte)2);
+        Integer issueReportId = issueSv.updateIssueReport(seIssueReport);
+        if(issueReportId == null) {
+            return BaseResponseUtils.buildErrorMsg("鍐滄埛闂涓婃姤淇敼澶辫触");
         }
 
         return BaseResponseUtils.buildSuccess(true) ;
@@ -153,6 +170,10 @@
      */
     @GetMapping(path = "/getReportReply")
     public BaseResponse<VoIssueReportReply> getReportReply(@RequestParam("reportId") Long reportId) {
+        if(reportId == null) {
+            return BaseResponseUtils.buildErrorMsg("璇烽�夋嫨涓�涓棶棰樹笂鎶�");
+        }
+
         try {
             return BaseResponseUtils.buildSuccess(issueSv.getReportReplyByReportId(reportId));
         } catch (Exception e) {

--
Gitblit v1.8.0