From 984cab3089b6b0adadcb91bed4adfc2fa2ee5003 Mon Sep 17 00:00:00 2001
From: yss <17921@qq.com>
Date: Tue, 18 Apr 2023 17:20:23 +0800
Subject: [PATCH] =?UTF-8?q?=E5=BE=85=E9=98=85=E5=8A=9F=E8=83=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../client/NotificationFeignClient.java       |  2 +-
 .../NotificationFeignFallbackFactory.java     |  2 +-
 .../controller/BizReadingController.java      | 19 +++++++-----
 .../NoticeReadingUpdateRequestBody.java       |  7 ++++-
 .../service/BizReadingService.java            |  4 ++-
 .../service/impl/BizReadingServiceImpl.java   | 29 ++++++++++++++++---
 6 files changed, 47 insertions(+), 16 deletions(-)

diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/client/NotificationFeignClient.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/client/NotificationFeignClient.java
index 1323887..8f28a9d 100644
--- a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/client/NotificationFeignClient.java
+++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/client/NotificationFeignClient.java
@@ -30,7 +30,7 @@ public interface NotificationFeignClient {
     @ApiOperation(value = "新增待阅", tags = "新增待阅", notes = "新增待阅")
     @PostMapping("/v1/notification/sendReading")
     @OperationLogDetail(businessModule = EbtpLogBusinessModule.OTHER,operationType = EbtpLogType.SELECT,detail = "待阅-新增")
-    BaseResponse sendPending(@Valid @RequestBody NoticeReadingPO noticeReadingPO);
+    BaseResponse sendReading(@Valid @RequestBody NoticeReadingPO noticeReadingPO);
 
     @ApiOperation(value = "待阅更新或删除", tags = "待阅更新或删除", notes = "待阅更新或删除")
     @PostMapping("/v1/notification/updateReading")
diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/client/NotificationFeignFallbackFactory.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/client/NotificationFeignFallbackFactory.java
index 29a5916..21c86c5 100644
--- a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/client/NotificationFeignFallbackFactory.java
+++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/client/NotificationFeignFallbackFactory.java
@@ -32,7 +32,7 @@ public class NotificationFeignFallbackFactory implements FallbackFactory<Notific
             }
 
             @Override
-            public BaseResponse sendPending(@Valid NoticeReadingPO noticeReadingPO) {
+            public BaseResponse sendReading(@Valid NoticeReadingPO noticeReadingPO) {
                 return BaseResponse.fail("云门户-新增待阅失败：" + ExceptionUtil.stacktraceToString(throwable), noticeReadingPO);
             }
 
diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/controller/BizReadingController.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/controller/BizReadingController.java
index 89b0834..fd0167c 100644
--- a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/controller/BizReadingController.java
+++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/controller/BizReadingController.java
@@ -8,16 +8,13 @@ import com.chinaunicom.mall.ebtp.extend.bizshortmessageemail.service.BizReadingS
 import com.chinaunicom.mall.ebtp.extend.bizshortmessageemail.service.BizSendMsgTemplateService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
-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 javax.annotation.Resource;
 
 @RestController
 @Api(tags = "待阅")
-@RequestMapping("/v1/send/reading")
+@RequestMapping("/v1/reading")
 public class BizReadingController {
 
     @Resource
@@ -25,13 +22,19 @@ public class BizReadingController {
 
     @ApiOperation("发送待阅")
     @PostMapping("save")
-    public BaseResponse sendPending(@RequestBody NoticeReadingPO noticeReadingPO) {
-        return BaseResponse.success(readingService.sendPending(noticeReadingPO));
+    public BaseResponse sendReading(@RequestBody NoticeReadingPO noticeReadingPO) {
+        return readingService.sendReading(noticeReadingPO);
     }
     @ApiOperation("待阅更新或删除-readingStatus:0:待阅 1:已阅 d:待阅删除")
     @PostMapping("update")
     public BaseResponse updateReading(@RequestBody NoticeReadingUpdateRequestBody noticeReadingUpdateRequestBody) {
-        return BaseResponse.success(readingService.updateReading(noticeReadingUpdateRequestBody));
+        return readingService.updateReading(noticeReadingUpdateRequestBody);
+    }
+
+    @ApiOperation("待阅更新1:已阅")
+    @PostMapping("updateReaded")
+    public BaseResponse updateReaded(@RequestParam String readingCode) {
+        return readingService.updateReaded(readingCode);
     }
 
 }
diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/entity/NoticeReadingUpdateRequestBody.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/entity/NoticeReadingUpdateRequestBody.java
index 2a0b564..08beffa 100644
--- a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/entity/NoticeReadingUpdateRequestBody.java
+++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/entity/NoticeReadingUpdateRequestBody.java
@@ -2,10 +2,15 @@ package com.chinaunicom.mall.ebtp.extend.bizshortmessageemail.entity;
 
 
 import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
 import org.hibernate.validator.constraints.Length;
 import javax.validation.constraints.NotBlank;
 
-
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
 public class NoticeReadingUpdateRequestBody {
 
     @ApiModelProperty("待阅信息的编号")
diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/service/BizReadingService.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/service/BizReadingService.java
index 68b3aa4..560bc53 100644
--- a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/service/BizReadingService.java
+++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/service/BizReadingService.java
@@ -15,7 +15,9 @@ import java.io.IOException;
 @Component
 public interface BizReadingService {
 
-    BaseResponse sendPending(NoticeReadingPO noticeReadingPO);
+    BaseResponse sendReading(NoticeReadingPO noticeReadingPO);
 
     BaseResponse updateReading(NoticeReadingUpdateRequestBody noticeReadingUpdateRequestBody);
+
+    BaseResponse updateReaded(String readingCode);
 }
diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/service/impl/BizReadingServiceImpl.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/service/impl/BizReadingServiceImpl.java
index fe7bf06..a8f2fba 100644
--- a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/service/impl/BizReadingServiceImpl.java
+++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/service/impl/BizReadingServiceImpl.java
@@ -12,6 +12,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
+import java.util.Date;
 
 /**
  * @author yanss
@@ -26,8 +27,7 @@ public class BizReadingServiceImpl implements BizReadingService {
     private IBaseCacheUserService cacheUserService;
 
     @Override
-    public BaseResponse sendPending(NoticeReadingPO noticeReadingPO) {
-//        noticeReadingPO.setSendCenter("na134");
+    public BaseResponse sendReading(NoticeReadingPO noticeReadingPO) {
         noticeReadingPO.setSendCenter("ebtp");
         noticeReadingPO.setSendModule("biz-service-ebtp-extend");
         if(StringUtils.isBlank(noticeReadingPO.getOperatorType())){
@@ -37,11 +37,32 @@ public class BizReadingServiceImpl implements BizReadingService {
             noticeReadingPO.setReadingSourceUserId(cacheUserService.getCacheUser().getUserId());
             noticeReadingPO.setReadingSourceUserCn(cacheUserService.getCacheUser().getFullName());
         }
-        return notificationFeignClient.sendPending(noticeReadingPO);
+        BaseResponse baseResponse=notificationFeignClient.sendReading(noticeReadingPO);
+        if(baseResponse.isSuccess() && baseResponse.getCode()==1){
+            BaseResponse.success(baseResponse.getMessage(),null);
+        }
+        return baseResponse;
     }
 
     @Override
     public BaseResponse updateReading(NoticeReadingUpdateRequestBody noticeReadingUpdateRequestBody) {
-        return notificationFeignClient.updateReading(noticeReadingUpdateRequestBody);
+        BaseResponse baseResponse=notificationFeignClient.updateReading(noticeReadingUpdateRequestBody);
+        if(baseResponse.isSuccess() && baseResponse.getCode()==1){
+            BaseResponse.success(baseResponse.getMessage(),null);
+        }
+        return baseResponse;
+    }
+
+    @Override
+    public BaseResponse updateReaded(String readingCode) {
+        NoticeReadingUpdateRequestBody noticeReadingUpdateRequestBody=new NoticeReadingUpdateRequestBody();
+        noticeReadingUpdateRequestBody.setReadingCode(readingCode);
+        noticeReadingUpdateRequestBody.setReadingStatus("1");
+        noticeReadingUpdateRequestBody.setReadingType("1");
+        BaseResponse baseResponse=notificationFeignClient.updateReading(noticeReadingUpdateRequestBody);
+        if(baseResponse.isSuccess() && baseResponse.getCode()==1){
+            BaseResponse.success(baseResponse.getMessage(),null);
+        }
+        return baseResponse;
     }
 }