wl
2022-10-24 9969bea2a8c1eab64c12a51a2d24d65e5b6c0dd0
ycl-platform/src/main/java/com/ycl/service/message/factory/InnerSender.java
@@ -4,6 +4,7 @@
import com.ycl.common.util.UtilNumber;
import com.ycl.dto.message.MessageParam;
import com.ycl.entity.message.Message;
import com.ycl.mapper.message.MessageMapper;
import com.ycl.service.message.IMessageService;
import com.ycl.service.message.Sender;
import org.springframework.beans.BeanUtils;
@@ -32,16 +33,41 @@
    public void setIMessageService(IMessageService iMessageService) {
        InnerSender.iMessageService = iMessageService;
    }
    private static MessageMapper messageMapper;
    @Autowired
    public void setMessageMapper(MessageMapper messageMapper) {
        InnerSender.messageMapper = messageMapper;
    }
    @Override
    public Message sendMessage(MessageParam messageParam) {
        Message message = new Message();
        List<Message> messages = new ArrayList<>();
        String[] ids = messageParam.getTargetTo().split(",");
        String messageNumber = UtilNumber.getNumber("MC", 6);
        List<Message> messages = new ArrayList<>();
        BeanUtils.copyProperties(messageParam, message);
        //父Id为0
        message.setParentId(0L);
        //生成消息编码
        message.setMessageNumber(messageNumber);
        //生成默认参数
        //发送时间
        if (message.getSendTime() == null) {
            message.setSendTime(new Date());
        }
        message.setIsView(0);
        message.setVersion(0);
        message.setIsScan(1);
        message.setCreateTime(new Date());
        message.setUpdateTime(new Date());
        message.setCreateUser(messageParam.getCreateUser());
        message.setUpdateUser(messageParam.getCreateUser());
        messageMapper.insert(message);
        String[] ids = messageParam.getTargetTo().split(",");
        for (String id : ids) {
            Message messageAdd = new Message();
            BeanUtils.copyProperties(messageParam, messageAdd);
            //设置父类Id
            messageAdd.setParentId(message.getId());
            //设置接收者
            messageAdd.setTargetTo(id);
            //生成8位随机数消息编码
@@ -64,7 +90,6 @@
            messageAdd.setVersion(0);
            messages.add(messageAdd);
        }
        BeanUtils.copyProperties(messageParam, message);
        //批量新增
        iMessageService.saveBatch(messages);
        return message;