TMessageInfoServiceImpl.java 4.44 KB
Newer Older
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145
package com.zehong.system.service.impl;

import com.zehong.common.utils.DateUtils;
import com.zehong.common.utils.SecurityUtils;
import com.zehong.system.domain.TMessageDetailInfo;
import com.zehong.system.domain.TMessageInfo;
import com.zehong.system.mapper.TMessageDetailInfoMapper;
import com.zehong.system.mapper.TMessageInfoMapper;
import com.zehong.system.service.ITMessageInfoService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.Date;
import java.util.List;

/**
 * 消息Service业务层处理
 * 
 * @author zehong
 * @date 2023-09-14
 */
@Service
public class TMessageInfoServiceImpl implements ITMessageInfoService 
{
    @Autowired
    private TMessageInfoMapper tMessageInfoMapper;

    @Autowired
    private TMessageDetailInfoMapper tMessageDetailInfoMapper;

    /**
     * 查询消息
     * 
     * @param messageId 消息ID
     * @return 消息
     */
    @Override
    public TMessageInfo selectTMessageInfoById(Long messageId)
    {
        return tMessageInfoMapper.selectTMessageInfoById(messageId);
    }

    /**
     * 查询消息列表
     * 
     * @param tMessageInfo 消息
     * @return 消息
     */
    @Override
    public List<TMessageInfo> selectTMessageInfoList(TMessageInfo tMessageInfo)
    {
        return tMessageInfoMapper.selectTMessageInfoList(tMessageInfo);
    }
    @Override
    public List<TMessageInfo> selectTMessageInfoListapp(TMessageInfo tMessageInfo)
    {
        return tMessageInfoMapper.selectTMessageInfoListapp(tMessageInfo);
    }


    /**
     * 新增消息
     * 
     * @param tMessageInfo 消息
     * @return 结果
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public int insertTMessageInfo(TMessageInfo tMessageInfo)
    {
        tMessageInfo.setCreateTime(DateUtils.getNowDate());
        tMessageInfo.setCreateBy(SecurityUtils.getUsername());
        int i = tMessageInfoMapper.insertTMessageInfo(tMessageInfo);

        if(tMessageInfo.getPersonIds()!=null&&tMessageInfo.getPersonIds().length>0){
            for (String personId:tMessageInfo.getPersonIds()){
                TMessageDetailInfo info = new TMessageDetailInfo();
                info.setMessageId(tMessageInfo.getMessageId());
                info.setCreateTime(new Date());
                info.setPersonId(Long.parseLong(personId));
                tMessageDetailInfoMapper.insertTMessageDetailInfo(info);
            }
        }else {
            for(TMessageDetailInfo tMessageDetailInfo : tMessageInfo.getMessageDetailInfoList()){
                tMessageDetailInfo.setMessageId(tMessageInfo.getMessageId());
                tMessageDetailInfo.setCreateTime(new Date());
                tMessageDetailInfoMapper.insertTMessageDetailInfo(tMessageDetailInfo);
            }
        }
        return i;
    }

    /**
     * 修改消息
     * 
     * @param tMessageInfo 消息
     * @return 结果
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public int updateTMessageInfo(TMessageInfo tMessageInfo)
    {
        tMessageInfo.setUpdateTime(DateUtils.getNowDate());
        int i = tMessageInfoMapper.updateTMessageInfo(tMessageInfo);
        if(tMessageInfo.getMessageDetailInfoList()!=null){
            tMessageDetailInfoMapper.deleteMessageDetailByMessageId(tMessageInfo.getMessageId());
            for(TMessageDetailInfo tMessageDetailInfo : tMessageInfo.getMessageDetailInfoList()){
                tMessageDetailInfo.setMessageId(tMessageInfo.getMessageId());
                tMessageDetailInfo.setCreateTime(new Date());
                tMessageDetailInfoMapper.insertTMessageDetailInfo(tMessageDetailInfo);
            }
        }

        return i;
    }

    /**
     * 批量删除消息
     * 
     * @param messageIds 需要删除的消息ID
     * @return 结果
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public int deleteTMessageInfoByIds(Long[] messageIds)
    {
        for(Long messageId :messageIds){
            tMessageDetailInfoMapper.deleteMessageDetailByMessageId(messageId);
        }
        return tMessageInfoMapper.deleteTMessageInfoByIds(messageIds);
    }

    /**
     * 删除消息信息
     * 
     * @param messageId 消息ID
     * @return 结果
     */
    @Override
    public int deleteTMessageInfoById(Long messageId)
    {
        return tMessageInfoMapper.deleteTMessageInfoById(messageId);
    }
}