liuchang/biz_service_ebtp_extend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

待阅功能

Browse Source
This commit is contained in:
yss
2023-04-18 13:57:45 +08:00
parent acff63646f
commit ab730ad2c5
1 changed files with 12 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/main/java/com/chinaunicom/mall/ebtp/extend/bizshortmessageemail/service/impl/BizReadingServiceImpl.java
View File

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