| | |
| | | /** 设备运行异常 */ |
| | | deviceRunError("deviceRunError", "设备运行异常", "device_run_error"), |
| | | /** 钉状态长期无变化 */ |
| | | statusPermanentlyNoChange("statusPermanentlyNoChange", "钉状态长期无变化", "status_permanently_no_change"), |
| | | statusPermanentlyNoChange("statusPermanentlyNoChange", "状态长期无变化", "status_permanently_no_change"), |
| | | /** 网络故障 */ |
| | | networkFault("networkFault", "网络故障", "network_fault"); |
| | | |
| | |
| | | MessageDTO messageDTO = new MessageDTO(); |
| | | messageDTO.setTitle(headInfo); |
| | | messageDTO.setFromUser("数据导入小助手-小导"); |
| | | messageDTO.setCategory("导入操作附加信息"); |
| | | messageDTO.setCategory("导入信息"); |
| | | messageDTO.setContent(exceptionInfo); |
| | | messageDTO.setToUser(user.getUsername()); |
| | | sysBaseApi.sendSysAnnouncement(messageDTO); |
| | |
| | | MessageDTO messageDTO = new MessageDTO(); |
| | | messageDTO.setTitle("有新的保养工单"); |
| | | messageDTO.setContent(msg); |
| | | messageDTO.setCategory("系统消息"); |
| | | messageDTO.setCategory("保养工单"); |
| | | messageDTO.setFromUser(user.getUsername()); |
| | | messageDTO.setToUser("admin"); |
| | | if(equipmentMaintenancePlanDetails.size()!=0){ |
| | |
| | | messageTitle = "系统消息:备件编码为 " + sparePart.getNum() + " 的备件库存量不足,请及时处理!"; |
| | | messageContent = "系统消息:备件编码:" + sparePart.getNum() + " 的备件库存量已低于安全库存!" + "\n" + "消息时间:" + sysTime + "\n"; |
| | | for (SysUser sysUser : sysUsers) { |
| | | sysBaseAPI.sendAnnouncement("admin", sysUser.getUsername(), messageTitle, messageContent); |
| | | sysBaseAPI.sendAnnouncement("admin", sysUser.getUsername(), messageTitle, messageContent, "备件库存量不足"); |
| | | } |
| | | }else if(quantity > sparePart.getInventoryUpperLimit()){ |
| | | String messageTitle; |
| | |
| | | messageTitle = "系统消息:备件编码为 " + sparePart.getNum() + " 的备件出现积压情况,请及时处理!"; |
| | | messageContent = "系统消息:备件编码为 " + sparePart.getNum() + " 的备件库存量已高于库存上限值,出现积压情况!" + "\n" + "消息时间:" + sysTime + "\n"; |
| | | for (SysUser sysUser : sysUsers) { |
| | | sysBaseAPI.sendAnnouncement("admin", sysUser.getUsername(), messageTitle, messageContent); |
| | | sysBaseAPI.sendAnnouncement("admin", sysUser.getUsername(), messageTitle, messageContent, "备件积压"); |
| | | } |
| | | } |
| | | return true; |
| | |
| | | messageTitle = "系统消息:备件编码为 " + sparePart.getNum() + " 的备件库存量不足,请及时处理!"; |
| | | messageContent = "系统消息:备件编码:" + sparePart.getNum() + " 的备件库存量已低于安全库存!" + "\n" + "消息时间:" + sysTime + "\n"; |
| | | for (SysUser sysUser : sysUsers) { |
| | | sysBaseAPI.sendAnnouncement("admin", sysUser.getUsername(), messageTitle, messageContent); |
| | | sysBaseAPI.sendAnnouncement("admin", sysUser.getUsername(), messageTitle, messageContent, "备件库存量不足"); |
| | | } |
| | | }else if(quantity > sparePart.getInventoryUpperLimit()){ |
| | | String messageTitle; |
| | |
| | | messageTitle = "系统消息:备件编码为 " + sparePart.getNum() + " 的备件出现积压情况,请及时处理!"; |
| | | messageContent = "系统消息:备件编码为 " + sparePart.getNum() + " 的备件库存量已高于库存上限值,出现积压情况!" + "\n" + "消息时间:" + sysTime + "\n"; |
| | | for (SysUser sysUser : sysUsers) { |
| | | sysBaseAPI.sendAnnouncement("admin", sysUser.getUsername(), messageTitle, messageContent); |
| | | sysBaseAPI.sendAnnouncement("admin", sysUser.getUsername(), messageTitle, messageContent, "备件积压"); |
| | | } |
| | | } |
| | | return true; |
| | |
| | | messageTitle = "系统消息:备件编码为 " + sparePart.getNum() + " 的备件库存量不足,请及时处理!"; |
| | | messageContent = "系统消息:备件编码:" + sparePart.getNum() + " 的备件库存量已低于安全库存!" + "\n" + "消息时间:" + sysTime + "\n"; |
| | | for (SysUser sysUser : sysUsers) { |
| | | sysBaseAPI.sendAnnouncement("admin", sysUser.getUsername(), messageTitle, messageContent); |
| | | sysBaseAPI.sendAnnouncement("admin", sysUser.getUsername(), messageTitle, messageContent, "备件库存量不足"); |
| | | } |
| | | }else if(quantity > sparePart.getInventoryUpperLimit()){ |
| | | String messageTitle; |
| | |
| | | messageTitle = "系统消息:备件编码为 " + sparePart.getNum() + " 的备件出现积压情况,请及时处理!"; |
| | | messageContent = "系统消息:备件编码为 " + sparePart.getNum() + " 的备件库存量已高于库存上限值,出现积压情况!" + "\n" + "消息时间:" + sysTime + "\n"; |
| | | for (SysUser sysUser : sysUsers) { |
| | | sysBaseAPI.sendAnnouncement("admin", sysUser.getUsername(), messageTitle, messageContent); |
| | | sysBaseAPI.sendAnnouncement("admin", sysUser.getUsername(), messageTitle, messageContent, "备件积压"); |
| | | } |
| | | } |
| | | return true; |
| | |
| | | * @param title 消息主题 |
| | | * @param msgContent 消息内容 |
| | | */ |
| | | public void sendAnnouncement(String fromUser, String toUser, String title, String msgContent); |
| | | public void sendAnnouncement(String fromUser, String toUser, String title, String msgContent, String category); |
| | | } |
| | |
| | | } |
| | | |
| | | @Override |
| | | public void sendAnnouncement(String fromUser, String toUser, String title, String msgContent) { |
| | | public void sendAnnouncement(String fromUser, String toUser, String title, String msgContent, String category) { |
| | | SysAnnouncement announcement = new SysAnnouncement(); |
| | | announcement.setTitile(title); |
| | | announcement.setMsgContent(msgContent); |
| | |
| | | announcement.setMsgType(CommonConstant.MSG_TYPE_UESR); |
| | | announcement.setSendStatus(CommonConstant.HAS_SEND); |
| | | announcement.setSendTime(new Date()); |
| | | announcement.setMsgCategory(CommonConstant.MSG_CATEGORY_2); |
| | | announcement.setMsgCategory(org.apache.commons.lang3.StringUtils.isNotBlank(category) ? category : CommonConstant.MSG_CATEGORY_2); |
| | | announcement.setDelFlag(String.valueOf(CommonConstant.DEL_FLAG_0)); |
| | | sysAnnouncementMapper.insert(announcement); |
| | | // 2.插入用户通告阅读标记表记录 |