package cn.lili.modules.member.serviceimpl;
|
|
import cn.hutool.core.text.CharSequenceUtil;
|
import cn.lili.common.enums.ResultCode;
|
import cn.lili.common.exception.ServiceException;
|
import cn.lili.modules.member.entity.dos.Member;
|
import cn.lili.modules.member.entity.dos.MemberNotice;
|
import cn.lili.modules.member.entity.dos.MemberNoticeSenter;
|
import cn.lili.modules.member.entity.enums.SendTypeEnum;
|
import cn.lili.modules.member.mapper.MemberNoticeSenterMapper;
|
import cn.lili.modules.member.service.MemberNoticeSenterService;
|
import cn.lili.modules.member.service.MemberNoticeService;
|
import cn.lili.modules.member.service.MemberService;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Propagation;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
|
/**
|
* 会员消息业务层实现
|
*
|
* @author Chopper
|
* @since 2020/11/17 3:44 下午
|
*/
|
@Service
|
@Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
|
public class MemberNoticeSenterServiceImpl extends ServiceImpl<MemberNoticeSenterMapper, MemberNoticeSenter> implements MemberNoticeSenterService {
|
|
/**
|
* 会员
|
*/
|
@Autowired
|
private MemberService memberService;
|
/**
|
* 会员站内信
|
*/
|
@Autowired
|
private MemberNoticeService memberNoticeService;
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public boolean customSave(MemberNoticeSenter memberNoticeSenter) {
|
|
if (this.saveOrUpdate(memberNoticeSenter)) {
|
List<MemberNotice> memberNotices = new ArrayList<>();
|
//如果是选中会员发送
|
if (memberNoticeSenter.getSendType().equals(SendTypeEnum.SELECT.name())) {
|
//判定消息是否有效
|
if (!CharSequenceUtil.isEmpty(memberNoticeSenter.getMemberIds())) {
|
String[] ids = memberNoticeSenter.getMemberIds().split(",");
|
MemberNotice memberNotice;
|
for (String id : ids) {
|
memberNotice = new MemberNotice();
|
memberNotice.setIsRead(false);
|
memberNotice.setContent(memberNoticeSenter.getContent());
|
memberNotice.setMemberId(id);
|
memberNotice.setTitle(memberNoticeSenter.getTitle());
|
memberNotices.add(memberNotice);
|
}
|
} else {
|
return true;
|
}
|
} //否则是全部会员发送
|
else {
|
List<Member> members = memberService.list();
|
MemberNotice memberNotice;
|
for (Member member : members) {
|
memberNotice = new MemberNotice();
|
memberNotice.setIsRead(false);
|
memberNotice.setContent(memberNoticeSenter.getContent());
|
memberNotice.setMemberId(member.getId());
|
memberNotice.setTitle(memberNoticeSenter.getTitle());
|
memberNotices.add(memberNotice);
|
}
|
}
|
//防止没有会员导致报错
|
if (!memberNotices.isEmpty()) {
|
//批量保存
|
if (memberNoticeService.saveBatch(memberNotices)) {
|
return true;
|
} else {
|
throw new ServiceException(ResultCode.NOTICE_SEND_ERROR);
|
}
|
}
|
}
|
return true;
|
}
|
}
|
