From ab730ad2c5d9e04fae675458210b150577a473b3 Mon Sep 17 00:00:00 2001
From: yss <17921@qq.com>
Date: Tue, 18 Apr 2023 13:57:45 +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

---
 .../service/impl/BizReadingServiceImpl.java          | 12 ++++++++++++
 1 file changed, 12 insertions(+)

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 013e662..fe7bf06 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
@@ -1,11 +1,14 @@
 package com.chinaunicom.mall.ebtp.extend.bizshortmessageemail.service.impl;
 
 import com.chinaunicom.mall.ebtp.common.base.entity.BaseResponse;
+import com.chinaunicom.mall.ebtp.common.base.service.IBaseCacheUserService;
 import com.chinaunicom.mall.ebtp.extend.bizshortmessageemail.client.NotificationFeignClient;
 import com.chinaunicom.mall.ebtp.extend.bizshortmessageemail.entity.NoticeReadingPO;
 import com.chinaunicom.mall.ebtp.extend.bizshortmessageemail.entity.NoticeReadingUpdateRequestBody;
 import com.chinaunicom.mall.ebtp.extend.bizshortmessageemail.service.BizReadingService;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
@@ -19,12 +22,21 @@ public class BizReadingServiceImpl implements BizReadingService {
 
     @Resource
     private NotificationFeignClient notificationFeignClient;
+    @Autowired
+    private IBaseCacheUserService cacheUserService;
 
     @Override
     public BaseResponse sendPending(NoticeReadingPO noticeReadingPO) {
 //        noticeReadingPO.setSendCenter("na134");
         noticeReadingPO.setSendCenter("ebtp");
         noticeReadingPO.setSendModule("biz-service-ebtp-extend");
+        if(StringUtils.isBlank(noticeReadingPO.getOperatorType())){
+            noticeReadingPO.setOperatorType("a");
+        }
+        if(StringUtils.isBlank(noticeReadingPO.getReadingSourceUserId())){
+            noticeReadingPO.setReadingSourceUserId(cacheUserService.getCacheUser().getUserId());
+            noticeReadingPO.setReadingSourceUserCn(cacheUserService.getCacheUser().getFullName());
+        }
         return notificationFeignClient.sendPending(noticeReadingPO);
     }