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);
     }