add 发送系统消息

This commit is contained in:
liao
2023-11-15 15:49:15 +08:00
parent c250e347fb
commit 958816e756
3 changed files with 32 additions and 3 deletions
@@ -1,15 +1,36 @@
package com.jero.modules.message.handle.impl;
import com.jero.common.system.vo.LoginUser;
import com.jero.common.util.SpringContextUtils;
import com.jero.common.util.UUIDUtils;
import com.jero.modules.system.entity.SysAnnouncement;
import com.jero.modules.system.service.ISysAnnouncementService;
import lombok.extern.slf4j.Slf4j;
import com.jero.modules.message.handle.ISendMsgHandle;
import org.apache.shiro.SecurityUtils;
import java.util.Date;
@Slf4j
public class SmsSendMsgHandle implements ISendMsgHandle {
@Override
public void SendMsg(String esReceiver, String esTitle, String esContent) {
// TODO Auto-generated method stub
log.info("发短信");
ISysAnnouncementService bean = SpringContextUtils.getBean(ISysAnnouncementService.class);
String id = UUIDUtils.randomUUID20();
LoginUser loginUser = (LoginUser) SecurityUtils.getSubject().getPrincipal();
SysAnnouncement sysAnnouncement = new SysAnnouncement();
sysAnnouncement.setId(id);
sysAnnouncement.setTitile(esTitle);
sysAnnouncement.setMsgContent(esContent);
sysAnnouncement.setSender(loginUser.getId());
sysAnnouncement.setMsgCategory("2");
sysAnnouncement.setMsgType("USER");
sysAnnouncement.setSendStatus("1");
sysAnnouncement.setSendTime(new Date());
sysAnnouncement.setDelFlag("0");
sysAnnouncement.setUserIds(esReceiver);
bean.saveAnnouncement(sysAnnouncement);
}
}
@@ -46,7 +46,8 @@ public class SysAnnouncementServiceImpl extends ServiceImpl<SysAnnouncementMappe
sysAnnouncementMapper.insert(sysAnnouncement);
// 2.插入用户通告阅读标记表记录
String userId = sysAnnouncement.getUserIds();
String[] userIds = userId.substring(0, (userId.length()-1)).split(",");
//String[] userIds = userId.substring(0, (userId.length()-1)).split(",");
String[] userIds = userId.split(",");
String anntId = sysAnnouncement.getId();
Date refDate = new Date();
for(int i=0;i<userIds.length;i++) {