| | |
|---|
| | | quartzJobService.deleteAndStopJob(quartzJob); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public void sendAnnouncement(String fromUser, String toUser, String title, String msgContent) { |
|---|
| | | SysAnnouncement announcement = new SysAnnouncement(); |
|---|
| | | announcement.setTitile(title); |
|---|
| | | announcement.setMsgContent(msgContent); |
|---|
| | | announcement.setSender(fromUser); |
|---|
| | | announcement.setPriority(CommonConstant.PRIORITY_M); |
|---|
| | | announcement.setMsgType(CommonConstant.MSG_TYPE_UESR); |
|---|
| | | announcement.setSendStatus(CommonConstant.HAS_SEND); |
|---|
| | | announcement.setSendTime(new Date()); |
|---|
| | | announcement.setMsgCategory(CommonConstant.MSG_CATEGORY_2); |
|---|
| | | announcement.setDelFlag(String.valueOf(CommonConstant.DEL_FLAG_0)); |
|---|
| | | sysAnnouncementMapper.insert(announcement); |
|---|
| | | // 2.插入用户通告阅读标记表记录 |
|---|
| | | String userId = toUser; |
|---|
| | | String[] userIds = userId.split(","); |
|---|
| | | String anntId = announcement.getId(); |
|---|
| | | for (int i = 0; i < userIds.length; i++) { |
|---|
| | | if (oConvertUtils.isNotEmpty(userIds[i])) { |
|---|
| | | SysUser sysUser = userMapper.getUserByName(userIds[i]); |
|---|
| | | if (sysUser == null) { |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | SysAnnouncementSend announcementSend = new SysAnnouncementSend(); |
|---|
| | | announcementSend.setAnntId(anntId); |
|---|
| | | announcementSend.setUserId(sysUser.getId()); |
|---|
| | | announcementSend.setReadFlag(CommonConstant.NO_READ_FLAG); |
|---|
| | | sysAnnouncementSendMapper.insert(announcementSend); |
|---|
| | | JSONObject obj = new JSONObject(); |
|---|
| | | obj.put("cmd", "user"); |
|---|
| | | obj.put("userId", sysUser.getId()); |
|---|
| | | obj.put("msgId", announcement.getId()); |
|---|
| | | obj.put("msgTxt", announcement.getTitile()); |
|---|
| | | webSocket.sendOneMessage(sysUser.getId(), obj.toJSONString()); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
