package jnpf.message.service.impl;
|
|
import cn.hutool.core.bean.BeanUtil;
|
import com.baomidou.dynamic.datasource.annotation.DSTransactional;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import jnpf.base.DictionaryDataApi;
|
import jnpf.base.Pagination;
|
import jnpf.base.UserInfo;
|
import jnpf.base.entity.DictionaryDataEntity;
|
import jnpf.base.entity.SuperBaseEntity;
|
import jnpf.base.service.SuperServiceImpl;
|
import jnpf.message.entity.MessageEntity;
|
import jnpf.message.entity.MessageMonitorEntity;
|
import jnpf.message.entity.MessageReceiveEntity;
|
import jnpf.message.mapper.MessageMapper;
|
import jnpf.message.mapper.MessageMonitorMapper;
|
import jnpf.message.mapper.MessagereceiveMapper;
|
import jnpf.message.model.MessageInfoVO;
|
import jnpf.message.model.NoticePagination;
|
import jnpf.message.model.NoticeVO;
|
import jnpf.message.model.PaginationMessage;
|
import jnpf.message.service.MessageService;
|
import jnpf.message.util.OnlineUserProvider;
|
import jnpf.message.util.PushMessageUtil;
|
import jnpf.permission.UserApi;
|
import jnpf.permission.entity.UserEntity;
|
import jnpf.util.*;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* 消息实例
|
*
|
* @author JNPF开发平台组
|
* @version V3.1.0
|
* @copyright 引迈信息技术有限公司
|
* @date 2019年9月27日 上午9:18
|
*/
|
@Service
|
@Slf4j
|
public class MessageServiceImpl extends SuperServiceImpl<MessageMapper, MessageEntity> implements MessageService {
|
|
@Autowired
|
private UserApi userApi;
|
|
@Autowired
|
private DictionaryDataApi dictionaryDataApi;
|
@Autowired
|
private MessagereceiveMapper messagereceiveMapper;
|
@Autowired
|
private MessageMonitorMapper messageMonitorMapper;
|
|
@Override
|
public List<MessageEntity> getNoticeList(NoticePagination pagination) {
|
return this.baseMapper.getNoticeList(pagination);
|
}
|
|
@Override
|
public List<MessageEntity> getDashboardNoticeList(List<String> typeList) {
|
List<MessageEntity> list = new ArrayList<>(16);
|
// 判断哪些消息是自己接收的
|
QueryWrapper<MessageReceiveEntity> queryWrapper = new QueryWrapper<>();
|
queryWrapper.lambda().eq(MessageReceiveEntity::getUserId, UserProvider.getUser().getUserId());
|
queryWrapper.lambda().eq(MessageReceiveEntity::getType, 1);
|
List<MessageReceiveEntity> receiveEntities = messagereceiveMapper.selectList(queryWrapper);
|
for (int i = 0; i < receiveEntities.size(); i++) {
|
// 得到message
|
MessageReceiveEntity messageReceiveEntity = receiveEntities.get(i);
|
try {
|
MessageEntity entity = JsonUtil.getJsonToBean(messageReceiveEntity.getBodyText(), MessageEntity.class);
|
if (entity != null) {
|
if (StringUtil.isNotEmpty(entity.getId())) {
|
MessageEntity messageEntity = this.getInfo(entity.getId());
|
if (messageEntity != null) {
|
if ((typeList != null && typeList.size() > 0 && typeList.contains(messageEntity.getCategory()) || typeList == null || typeList.size() == 0)) {
|
if (Objects.equals(messageEntity.getEnabledMark(), 1)
|
&& (entity.getExpirationTime() == null || entity.getExpirationTime().getTime() > System.currentTimeMillis())) {
|
messageEntity.setId(messageReceiveEntity.getId());
|
list.add(messageEntity);
|
}
|
}
|
}
|
} else {
|
entity.setId(messageReceiveEntity.getId());
|
list.add(entity);
|
}
|
}
|
} catch (Exception e) {
|
MessageEntity messageEntity = JsonUtil.getJsonToBean(messageReceiveEntity, MessageEntity.class);
|
list.add(messageEntity);
|
}
|
if (list.size() > 49) {
|
break;
|
}
|
}
|
list = list.stream().sorted(Comparator.comparing(MessageEntity::getLastModifyTime, Comparator.nullsFirst(Comparator.naturalOrder())).reversed()).collect(Collectors.toList());
|
return list;
|
}
|
|
@Override
|
public List<MessageReceiveEntity> getMessageList3(PaginationMessage pagination) {
|
List<MessageReceiveEntity> messageColumnList = messagereceiveMapper.getMessageColumnList(pagination);
|
return messageColumnList;
|
}
|
|
@Override
|
public List<MessageReceiveEntity> getMessageList(Pagination pagination) {
|
PaginationMessage paginationMessage = BeanUtil.copyProperties(pagination, PaginationMessage.class);
|
return this.getMessageList3(paginationMessage);
|
}
|
|
@Override
|
public MessageEntity getInfo(String id) {
|
return this.baseMapper.getInfo(id);
|
}
|
|
@Override
|
public MessageEntity getInfoDefault(int type) {
|
return this.baseMapper.getInfoDefault(type);
|
}
|
|
@Override
|
@DSTransactional
|
public void delete(MessageEntity entity) {
|
entity.setEnabledMark(-1);
|
this.updateById(entity);
|
this.removeById(entity.getId());
|
}
|
|
@Override
|
public void create(MessageEntity entity) {
|
this.baseMapper.create(entity);
|
}
|
|
@Override
|
public boolean update(String id, MessageEntity entity) {
|
return this.baseMapper.update(id, entity);
|
}
|
|
@Override
|
public MessageReceiveEntity messageRead(String messageId) {
|
return messagereceiveMapper.messageRead(messageId);
|
}
|
|
@Override
|
@DSTransactional
|
public void messageRead(List<String> idList) {
|
messagereceiveMapper.messageRead(idList);
|
}
|
|
@Override
|
@DSTransactional
|
public void deleteRecord(List<String> messageIds) {
|
messagereceiveMapper.deleteRecord(messageIds);
|
}
|
|
@Override
|
public int getUnreadCount(String userId, Integer type) {
|
return this.baseMapper.getUnreadCount(userId, type);
|
}
|
|
@Override
|
@DSTransactional
|
public void sentMessage(List<String> toUserIds, String title, String bodyText) {
|
messagereceiveMapper.sentMessage(toUserIds, title, bodyText);
|
}
|
|
@Override
|
@DSTransactional
|
public void sentMessage(List<String> toUserIds, String title, String bodyText, UserInfo userInfo, Integer source, Integer type) {
|
sentMessage(toUserIds, title, bodyText, userInfo, source, type, false);
|
}
|
|
@Override
|
@DSTransactional
|
public void sentMessage(List<String> toUserIds, String title, String bodyText, UserInfo userInfo, Integer source, Integer type, boolean testMessage) {
|
MessageReceiveEntity messageReceiveEntity = new MessageReceiveEntity();
|
messageReceiveEntity.setTitle(title);
|
messageReceiveEntity.setType(source);
|
messageReceiveEntity.setFlowType(1);
|
messageReceiveEntity.setBodyText(bodyText);
|
messageReceiveEntity.setIsRead(0);
|
Map<String, MessageReceiveEntity> map = new HashMap<>();
|
for (String item : toUserIds) {
|
MessageReceiveEntity messageReceiveEntitys = new MessageReceiveEntity();
|
BeanUtils.copyProperties(messageReceiveEntity, messageReceiveEntitys);
|
messageReceiveEntitys.setId(RandomUtil.uuId());
|
messageReceiveEntitys.setUserId(item);
|
messagereceiveMapper.insert(messageReceiveEntitys);
|
map.put(messageReceiveEntitys.getUserId(), messageReceiveEntitys);
|
}
|
//消息监控写入
|
MessageMonitorEntity monitorEntity = new MessageMonitorEntity();
|
monitorEntity.setId(RandomUtil.uuId());
|
monitorEntity.setTitle(title);
|
monitorEntity.setMessageType(String.valueOf(type));
|
monitorEntity.setMessageSource(String.valueOf(source));
|
monitorEntity.setReceiveUser(JsonUtil.getObjectToString(toUserIds));
|
monitorEntity.setSendTime(DateUtil.getNowDate());
|
monitorEntity.setCreatorTime(DateUtil.getNowDate());
|
monitorEntity.setCreatorUserId(userInfo.getUserId());
|
messageMonitorMapper.insert(monitorEntity);
|
PushMessageUtil.pushMessage(map, userInfo, source);
|
}
|
|
@Override
|
public void logoutWebsocketByToken(String token, String userId) {
|
if (StringUtil.isNotEmpty(token)) {
|
OnlineUserProvider.removeWebSocketByToken(token.split(","));
|
} else {
|
OnlineUserProvider.removeWebSocketByUser(userId);
|
}
|
}
|
|
@Override
|
public Boolean updateEnabledMark() {
|
return this.baseMapper.updateEnabledMark();
|
}
|
|
public List<NoticeVO> getNoticeList(List<String> list) {
|
List<MessageEntity> dashboardNoticeList = this.getDashboardNoticeList(list);
|
List<UserEntity> userList = userApi.getUserName(dashboardNoticeList.stream().map(MessageEntity::getCreatorUserId).collect(Collectors.toList()));
|
List<DictionaryDataEntity> noticeType = dictionaryDataApi.getListByCode("NoticeType");
|
dashboardNoticeList.forEach(t -> {
|
// 转换创建人、发布人
|
UserEntity user = userList.stream().filter(ul -> ul.getId().equals(t.getCreatorUserId())).findFirst().orElse(null);
|
t.setCreatorUserId(user != null ? user.getRealName() + "/" + user.getAccount() : "");
|
if (t.getEnabledMark() != null && t.getEnabledMark() != 0) {
|
UserEntity entity = userApi.getInfoById(t.getLastModifyUserId());
|
t.setLastModifyUserId(entity != null ? entity.getRealName() + "/" + entity.getAccount() : "");
|
}
|
DictionaryDataEntity dictionaryDataEntity = noticeType.stream().filter(notice -> notice.getEnCode().equals(t.getCategory())).findFirst().orElse(new DictionaryDataEntity());
|
t.setCategory(dictionaryDataEntity.getFullName());
|
});
|
List<NoticeVO> jsonToList = new ArrayList<>();
|
dashboardNoticeList.forEach(t -> {
|
NoticeVO vo = JsonUtil.getJsonToBean(t, NoticeVO.class);
|
vo.setReleaseTime(t.getLastModifyTime() != null ? t.getLastModifyTime().getTime() : null);
|
vo.setReleaseUser(t.getLastModifyUserId());
|
vo.setCreatorUser(t.getCreatorUserId());
|
jsonToList.add(vo);
|
});
|
return jsonToList;
|
}
|
|
@Override
|
public List<MessageInfoVO> getUserMessageList() {
|
List<MessageInfoVO> listVO = new ArrayList<>();
|
PaginationMessage pagination = new PaginationMessage();
|
pagination.setPageSize(5);
|
pagination.setUserId(UserProvider.getUser().getUserId());
|
List<MessageReceiveEntity> list = this.getMessageList3(pagination);
|
List<UserEntity> userList = userApi.getUserName(list.stream().map(SuperBaseEntity.SuperCBaseEntity::getCreatorUserId).collect(Collectors.toList()));
|
List<DictionaryDataEntity> msgSourceTypeList = dictionaryDataApi.getListByCode("msgSourceType");
|
list.forEach(t -> {
|
MessageInfoVO vo = JsonUtil.getJsonToBean(t, MessageInfoVO.class);
|
UserEntity user = userList.stream().filter(ul -> ul.getId().equals(t.getCreatorUserId())).findFirst().orElse(null);
|
if (user != null) {
|
vo.setReleaseTime(t.getCreatorTime() != null ? t.getCreatorTime().getTime() : null);
|
vo.setReleaseUser(user.getRealName() + "/" + user.getAccount());
|
vo.setCreatorUser(user.getRealName() + "/" + user.getAccount());
|
}
|
if (t.getType() != null) {
|
msgSourceTypeList.stream().filter(m -> t.getType().toString().equals(m.getEnCode())).findFirst()
|
.ifPresent(n -> vo.setTypeName(n.getFullName()));
|
}
|
listVO.add(vo);
|
});
|
return listVO;
|
}
|
|
}
|
