统一处理bug

mg

2022-10-26 992dd0cdea25df19651b243082171404bb796cbf

 ycl-platform/src/main/java/com/ycl/service/message/factory/InnerSender.java

@@ -1,6 +1,7 @@
package com.ycl.service.message.factory;

import com.ycl.common.constant.ChannelCode;
import com.ycl.common.util.CommonUtils;
import com.ycl.common.util.UtilNumber;
import com.ycl.dto.message.MessageParam;
import com.ycl.entity.message.Message;
@@ -42,8 +43,9 @@
    @Override
    public Message sendMessage(MessageParam messageParam) {
        Message message = new Message();
        String messageNumber = UtilNumber.getNumber("MC", 6);
        List<Message> messages = new ArrayList<>();
        if (CommonUtils.isEmpty(messageParam.getId())) {
            String messageNumber = UtilNumber.getNumber("MC", 6);
        BeanUtils.copyProperties(messageParam, message);
        //父Id为0
        message.setParentId(0L);
@@ -62,6 +64,15 @@
        message.setCreateUser(messageParam.getCreateUser());
        message.setUpdateUser(messageParam.getCreateUser());
        messageMapper.insert(message);
        } else {
            message.setId(messageParam.getId());
            BeanUtils.copyProperties(messageParam, message);
            message.setUpdateTime(new Date());
            message.setUpdateUser(messageParam.getCreateUser());
            messageMapper.updateById(message);
        }
        //发布消息
        if (message.getStatus() == 1) {
        String[] ids = messageParam.getTargetTo().split(",");
        for (String id : ids) {
            Message messageAdd = new Message();
@@ -71,7 +82,7 @@
            //设置接收者
            messageAdd.setTargetTo(id);
            //生成8位随机数消息编码
            messageAdd.setMessageNumber(messageNumber);
                messageAdd.setMessageNumber(message.getMessageNumber());
            //发送时间
            if (messageAdd.getSendTime() == null) {
                messageAdd.setSendTime(new Date());
@@ -92,6 +103,7 @@
        }
        //批量新增
        iMessageService.saveBatch(messages);
        }
        return message;
    }
}