package com.supersavedriving.driver.modular.system.service.impl;
|
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.baomidou.mybatisplus.service.impl.ServiceImpl;
|
import com.supersavedriving.driver.modular.system.dao.SystemMessageMapper;
|
import com.supersavedriving.driver.modular.system.warpper.SystemMessageWarpper;
|
import com.supersavedriving.driver.modular.system.model.SystemMessage;
|
import com.supersavedriving.driver.modular.system.service.ISystemMessageService;
|
import org.springframework.stereotype.Service;
|
|
import java.util.Date;
|
import java.util.List;
|
|
/**
|
* 系统消息逻辑类
|
* @author pzb
|
* @Date 2023/2/10 15:34
|
*/
|
@Service
|
public class SystemMessageServiceImpl extends ServiceImpl<SystemMessageMapper, SystemMessage> implements ISystemMessageService {
|
|
|
/**
|
* 获取个人系统消息列表
|
* @param uid
|
* @param pageNum
|
* @param size
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
public List<SystemMessageWarpper> querySystemMessageList(Integer uid, Integer pageNum, Integer size) throws Exception {
|
pageNum = (pageNum - 1) * size;
|
List<SystemMessageWarpper> systemMessageWarppers = this.baseMapper.querySystemMessageList(uid, pageNum, size);
|
return systemMessageWarppers;
|
}
|
|
|
/**
|
* 阅读系统消息
|
* @param uid
|
* @param ids
|
* @throws Exception
|
*/
|
@Override
|
public void readSystems(Integer uid, String ids) throws Exception {
|
String[] split = ids.split(",");
|
List<SystemMessage> systemMessages = this.selectList(new EntityWrapper<SystemMessage>().in("id", split));
|
for (SystemMessage systemMessage : systemMessages) {
|
systemMessage.setIsRead(1);
|
}
|
this.updateBatchById(systemMessages);
|
}
|
|
|
@Override
|
public void addSystemMessage(Integer userId, Integer userType, String title, String content) {
|
SystemMessage systemMessage = new SystemMessage();
|
systemMessage.setIsRead(0);
|
systemMessage.setContent(content);
|
systemMessage.setCreateTime(new Date());
|
systemMessage.setStatus(1);
|
systemMessage.setTitle(title);
|
systemMessage.setUserId(userId);
|
systemMessage.setUserType(userType);
|
this.insert(systemMessage);
|
}
|
|
@Override
|
public void clearSystemMessage(Integer userId) throws Exception {
|
this.baseMapper.clearSystemMessage(userId);
|
}
|
}
|
