源码类别
热门源码
 当前位置：源码 > Java源码 >

Java源码示例：org.jeecg.modules.message.entity.SysMessageTemplate

示例1
/**
 * 发送消息
 */
@PostMapping(value = "/sendMsg")
public Result<SysMessageTemplate> sendMessage(@RequestBody MsgParams msgParams) {
	Result<SysMessageTemplate> result = new Result<SysMessageTemplate>();
	Map<String, String> map = null;
	try {
		map = (Map<String, String>) JSON.parse(msgParams.getTestData());
	} catch (Exception e) {
		result.error500("解析Json出错！");
		return result;
	}
	boolean is_sendSuccess = pushMsgUtil.sendMessage(msgParams.getMsgType(), msgParams.getTemplateCode(), map, msgParams.getReceiver());
	if (is_sendSuccess) {
		result.success("发送消息任务添加成功！");
	} else {
		result.error500("发送消息任务添加失败！");
	}
	return result;
}
示例2
@Override
public String parseTemplateByCode(String templateCode,Map<String, String> map) {
    List<SysMessageTemplate> sysSmsTemplates = sysMessageTemplateService.selectByCode(templateCode);
    if(sysSmsTemplates==null||sysSmsTemplates.size()==0){
        throw new JeecgBootException("消息模板不存在，模板编码："+templateCode);
    }
    SysMessageTemplate sysSmsTemplate = sysSmsTemplates.get(0);
    //模板内容
    String content = sysSmsTemplate.getTemplateContent();
    if(map!=null) {
        for (Map.Entry<String, String> entry : map.entrySet()) {
            String str = "${" + entry.getKey() + "}";
            content = content.replace(str, entry.getValue());
        }
    }
    return content;
}
示例3
/**
 * 发送消息
 */
@PostMapping(value = "/sendMsg")
public Result<SysMessageTemplate> sendMessage(@RequestBody MsgParams msgParams) {
	Result<SysMessageTemplate> result = new Result<SysMessageTemplate>();
	Map<String, String> map = null;
	try {
		map = (Map<String, String>) JSON.parse(msgParams.getTestData());
	} catch (Exception e) {
		result.error500("解析Json出错！");
		return result;
	}
	boolean is_sendSuccess = pushMsgUtil.sendMessage(msgParams.getMsgType(), msgParams.getTemplateCode(), map, msgParams.getReceiver());
	if (is_sendSuccess) {
		result.success("发送消息任务添加成功！");
	} else {
		result.error500("发送消息任务添加失败！");
	}
	return result;
}
示例4
/**
 * 发送消息
 */
@PostMapping(value = "/sendMsg")
public Result<SysMessageTemplate> sendMessage(@RequestBody MsgParams msgParams) {
	Result<SysMessageTemplate> result = new Result<SysMessageTemplate>();
	Map<String, String> map = null;
	try {
		map = (Map<String, String>) JSON.parse(msgParams.getTestData());
	} catch (Exception e) {
		result.error500("解析Json出错！");
		return result;
	}
	boolean is_sendSuccess = pushMsgUtil.sendMessage(msgParams.getMsgType(), msgParams.getTemplateCode(), map, msgParams.getReceiver());
	if (is_sendSuccess) {
		result.success("发送消息任务添加成功！");
	} else {
		result.error500("发送消息任务添加失败！");
	}
	return result;
}
示例5
@Override
public String parseTemplateByCode(String templateCode,Map<String, String> map) {
    List<SysMessageTemplate> sysSmsTemplates = sysMessageTemplateService.selectByCode(templateCode);
    if(sysSmsTemplates==null||sysSmsTemplates.size()==0){
        throw new JeecgBootException("消息模板不存在，模板编码："+templateCode);
    }
    SysMessageTemplate sysSmsTemplate = sysSmsTemplates.get(0);
    //模板内容
    String content = sysSmsTemplate.getTemplateContent();
    if(map!=null) {
        for (Map.Entry<String, String> entry : map.entrySet()) {
            String str = "${" + entry.getKey() + "}";
            content = content.replace(str, entry.getValue());
        }
    }
    return content;
}
示例6
/**
 * 发送消息
 */
@PostMapping(value = "/sendMsg")
public Result<SysMessageTemplate> sendMessage(@RequestBody MsgParams msgParams) {
	Result<SysMessageTemplate> result = new Result<SysMessageTemplate>();
	Map<String, String> map = null;
	try {
		map = (Map<String, String>) JSON.parse(msgParams.getTestData());
	} catch (Exception e) {
		result.error500("解析Json出错！");
		return result;
	}
	boolean is_sendSuccess = pushMsgUtil.sendMessage(msgParams.getMsgType(), msgParams.getTemplateCode(), map, msgParams.getReceiver());
	if (is_sendSuccess) {
		result.success("发送消息任务添加成功！");
	} else {
		result.error500("发送消息任务添加失败！");
	}
	return result;
}
示例7
@Override
public String parseTemplateByCode(String templateCode,Map<String, String> map) {
    List<SysMessageTemplate> sysSmsTemplates = sysMessageTemplateService.selectByCode(templateCode);
    if(sysSmsTemplates==null||sysSmsTemplates.size()==0){
        throw new JeecgBootException("消息模板不存在，模板编码："+templateCode);
    }
    SysMessageTemplate sysSmsTemplate = sysSmsTemplates.get(0);
    //模板内容
    String content = sysSmsTemplate.getTemplateContent();
    if(map!=null) {
        for (Map.Entry<String, String> entry : map.entrySet()) {
            String str = "${" + entry.getKey() + "}";
            content = content.replace(str, entry.getValue());
        }
    }
    return content;
}
示例8
/**
  * @param msgType 消息类型 1短信 2邮件 3微信
  * @param templateCode    消息模板码
  * @param map     消息参数
  * @param sentTo  接收消息方
  */
 public boolean sendMessage(String msgType, String templateCode, Map<String, String> map, String sentTo) {
     List<SysMessageTemplate> sysSmsTemplates = sysMessageTemplateService.selectByCode(templateCode);
     SysMessage sysMessage = new SysMessage();
     if (sysSmsTemplates.size() > 0) {
         SysMessageTemplate sysSmsTemplate = sysSmsTemplates.get(0);
         sysMessage.setEsType(msgType);
         sysMessage.setEsReceiver(sentTo);
         //模板标题
         String title = sysSmsTemplate.getTemplateName();
         //模板内容
         String content = sysSmsTemplate.getTemplateContent();
         if(map!=null) {
         	 for (Map.Entry<String, String> entry : map.entrySet()) {
                  String str = "${" + entry.getKey() + "}";
                  title = title.replace(str, entry.getValue());
                  content = content.replace(str, entry.getValue());
              }
         }
         sysMessage.setEsTitle(title);
         sysMessage.setEsContent(content);
         sysMessage.setEsParam(JSONObject.toJSONString(map));
         sysMessage.setEsSendTime(new Date());
         sysMessage.setEsSendStatus(SendMsgStatusEnum.WAIT.getCode());
         sysMessage.setEsSendNum(0);
         if(sysMessageService.save(sysMessage)) {
	return true;
}
     }
     return false;
 }
示例9
/**
  * @param msgType 消息类型 1短信 2邮件 3微信
  * @param templateCode    消息模板码
  * @param map     消息参数
  * @param sentTo  接收消息方
  */
 public boolean sendMessage(String msgType, String templateCode, Map<String, String> map, String sentTo) {
     List<SysMessageTemplate> sysSmsTemplates = sysMessageTemplateService.selectByCode(templateCode);
     SysMessage sysMessage = new SysMessage();
     if (sysSmsTemplates.size() > 0) {
         SysMessageTemplate sysSmsTemplate = sysSmsTemplates.get(0);
         sysMessage.setEsType(msgType);
         sysMessage.setEsReceiver(sentTo);
         //模板标题
         String title = sysSmsTemplate.getTemplateName();
         //模板内容
         String content = sysSmsTemplate.getTemplateContent();
         if(map!=null) {
         	 for (Map.Entry<String, String> entry : map.entrySet()) {
                  String str = "${" + entry.getKey() + "}";
                  title = title.replace(str, entry.getValue());
                  content = content.replace(str, entry.getValue());
              }
         }
         sysMessage.setEsTitle(title);
         sysMessage.setEsContent(content);
         sysMessage.setEsParam(JSONObject.toJSONString(map));
         sysMessage.setEsSendTime(new Date());
         sysMessage.setEsSendStatus(SendMsgStatusEnum.WAIT.getCode());
         sysMessage.setEsSendNum(0);
         if(sysMessageService.save(sysMessage)) {
	return true;
}
     }
     return false;
 }
示例10
/**
  * @param msgType 消息类型 1短信 2邮件 3微信
  * @param templateCode    消息模板码
  * @param map     消息参数
  * @param sentTo  接收消息方
  */
 public boolean sendMessage(String msgType, String templateCode, Map<String, String> map, String sentTo) {
     List<SysMessageTemplate> sysSmsTemplates = sysMessageTemplateService.selectByCode(templateCode);
     SysMessage sysMessage = new SysMessage();
     if (sysSmsTemplates.size() > 0) {
         SysMessageTemplate sysSmsTemplate = sysSmsTemplates.get(0);
         sysMessage.setEsType(msgType);
         sysMessage.setEsReceiver(sentTo);
         //模板标题
         String title = sysSmsTemplate.getTemplateName();
         //模板内容
         String content = sysSmsTemplate.getTemplateContent();
         if(map!=null) {
         	 for (Map.Entry<String, String> entry : map.entrySet()) {
                  String str = "${" + entry.getKey() + "}";
                  title = title.replace(str, entry.getValue());
                  content = content.replace(str, entry.getValue());
              }
         }
         sysMessage.setEsTitle(title);
         sysMessage.setEsContent(content);
         sysMessage.setEsParam(JSONObject.toJSONString(map));
         sysMessage.setEsSendTime(new Date());
         sysMessage.setEsSendStatus(SendMsgStatusEnum.WAIT.getCode());
         sysMessage.setEsSendNum(0);
         if(sysMessageService.save(sysMessage)) {
	return true;
}
     }
     return false;
 }
示例11
/**
  * @param msgType 消息类型 1短信 2邮件 3微信
  * @param templateCode    消息模板码
  * @param map     消息参数
  * @param sentTo  接收消息方
  */
 public boolean sendMessage(String msgType, String templateCode, Map<String, String> map, String sentTo) {
     List<SysMessageTemplate> sysSmsTemplates = sysMessageTemplateService.selectByCode(templateCode);
     SysMessage sysMessage = new SysMessage();
     if (sysSmsTemplates.size() > 0) {
         SysMessageTemplate sysSmsTemplate = sysSmsTemplates.get(0);
         sysMessage.setEsType(msgType);
         sysMessage.setEsReceiver(sentTo);
         //模板标题
         String title = sysSmsTemplate.getTemplateName();
         //模板内容
         String content = sysSmsTemplate.getTemplateContent();
         if(map!=null) {
         	 for (Map.Entry<String, String> entry : map.entrySet()) {
                  String str = "${" + entry.getKey() + "}";
                  title = title.replace(str, entry.getValue());
                  content = content.replace(str, entry.getValue());
              }
         }
         sysMessage.setEsTitle(title);
         sysMessage.setEsContent(content);
         sysMessage.setEsParam(JSONObject.toJSONString(map));
         sysMessage.setEsSendTime(new Date());
         sysMessage.setEsSendStatus(SendMsgStatusEnum.WAIT.getCode());
         sysMessage.setEsSendNum(0);
         if(sysMessageService.save(sysMessage)) {
	return true;
}
     }
     return false;
 }
示例12
@Override
public List<SysMessageTemplate> selectByCode(String code) {
    return sysMessageTemplateMapper.selectByCode(code);
}
示例13
@Select("SELECT * FROM SYS_SMS_TEMPLATE WHERE TEMPLATE_CODE = #{code}")
List<SysMessageTemplate> selectByCode(String code);
示例14
@Override
public void sendSysAnnouncement(String fromUser, String toUser,String title,Map<String, String> map, String templateCode) {
	List<SysMessageTemplate> sysSmsTemplates = sysMessageTemplateService.selectByCode(templateCode);
       if(sysSmsTemplates==null||sysSmsTemplates.size()==0){
           throw new JeecgBootException("消息模板不存在，模板编码："+templateCode);
       }
	SysMessageTemplate sysSmsTemplate = sysSmsTemplates.get(0);
	//模板标题
	title = title==null?sysSmsTemplate.getTemplateName():title;
	//模板内容
	String content = sysSmsTemplate.getTemplateContent();
	if(map!=null) {
		for (Map.Entry<String, String> entry : map.entrySet()) {
			String str = "${" + entry.getKey() + "}";
			title = title.replace(str, entry.getValue());
			content = content.replace(str, entry.getValue());
		}
	}

	SysAnnouncement announcement = new SysAnnouncement();
	announcement.setTitile(title);
	announcement.setMsgContent(content);
	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(WebsocketConst.MSG_CMD, WebsocketConst.CMD_USER);
			obj.put(WebsocketConst.MSG_USER_ID, sysUser.getId());
			obj.put(WebsocketConst.MSG_ID, announcement.getId());
			obj.put(WebsocketConst.MSG_TXT, announcement.getTitile());
			webSocket.sendOneMessage(sysUser.getId(), obj.toJSONString());
		}
	}
}
示例15
@Override
public void sendSysAnnouncement(String fromUser, String toUser, String title, Map<String, String> map, String templateCode, String busType, String busId) {
	List<SysMessageTemplate> sysSmsTemplates = sysMessageTemplateService.selectByCode(templateCode);
	if(sysSmsTemplates==null||sysSmsTemplates.size()==0){
		throw new JeecgBootException("消息模板不存在，模板编码："+templateCode);
	}
	SysMessageTemplate sysSmsTemplate = sysSmsTemplates.get(0);
	//模板标题
	title = title==null?sysSmsTemplate.getTemplateName():title;
	//模板内容
	String content = sysSmsTemplate.getTemplateContent();
	if(map!=null) {
		for (Map.Entry<String, String> entry : map.entrySet()) {
			String str = "${" + entry.getKey() + "}";
			title = title.replace(str, entry.getValue());
			content = content.replace(str, entry.getValue());
		}
	}
	SysAnnouncement announcement = new SysAnnouncement();
	announcement.setTitile(title);
	announcement.setMsgContent(content);
	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));
	announcement.setBusId(busId);
	announcement.setBusType(busType);
	announcement.setOpenType(SysAnnmentTypeEnum.getByType(busType).getOpenType());
	announcement.setOpenPage(SysAnnmentTypeEnum.getByType(busType).getOpenPage());
	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(WebsocketConst.MSG_CMD, WebsocketConst.CMD_USER);
			obj.put(WebsocketConst.MSG_USER_ID, sysUser.getId());
			obj.put(WebsocketConst.MSG_ID, announcement.getId());
			obj.put(WebsocketConst.MSG_TXT, announcement.getTitile());
			webSocket.sendOneMessage(sysUser.getId(), obj.toJSONString());
		}
	}
}
示例16
@Override
public List<SysMessageTemplate> selectByCode(String code) {
    return sysMessageTemplateMapper.selectByCode(code);
}
示例17
@Select("SELECT * FROM SYS_SMS_TEMPLATE WHERE TEMPLATE_CODE = #{code}")
List<SysMessageTemplate> selectByCode(String code);
示例18
@Override
public List<SysMessageTemplate> selectByCode(String code) {
    return sysMessageTemplateMapper.selectByCode(code);
}
示例19
@Select("SELECT * FROM SYS_SMS_TEMPLATE WHERE TEMPLATE_CODE = #{code}")
List<SysMessageTemplate> selectByCode(String code);
示例20
@Override
public void sendSysAnnouncement(String fromUser, String toUser,String title,Map<String, String> map, String templateCode) {
	List<SysMessageTemplate> sysSmsTemplates = sysMessageTemplateService.selectByCode(templateCode);
       if(sysSmsTemplates==null||sysSmsTemplates.size()==0){
           throw new JeecgBootException("消息模板不存在，模板编码："+templateCode);
       }
	SysMessageTemplate sysSmsTemplate = sysSmsTemplates.get(0);
	//模板标题
	title = title==null?sysSmsTemplate.getTemplateName():title;
	//模板内容
	String content = sysSmsTemplate.getTemplateContent();
	if(map!=null) {
		for (Map.Entry<String, String> entry : map.entrySet()) {
			String str = "${" + entry.getKey() + "}";
			title = title.replace(str, entry.getValue());
			content = content.replace(str, entry.getValue());
		}
	}

	SysAnnouncement announcement = new SysAnnouncement();
	announcement.setTitile(title);
	announcement.setMsgContent(content);
	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());
		}
	}
}
示例21
@Override
public void sendSysAnnouncement(String fromUser, String toUser, String title, Map<String, String> map, String templateCode, String busType, String busId) {
	List<SysMessageTemplate> sysSmsTemplates = sysMessageTemplateService.selectByCode(templateCode);
	if(sysSmsTemplates==null||sysSmsTemplates.size()==0){
		throw new JeecgBootException("消息模板不存在，模板编码："+templateCode);
	}
	SysMessageTemplate sysSmsTemplate = sysSmsTemplates.get(0);
	//模板标题
	title = title==null?sysSmsTemplate.getTemplateName():title;
	//模板内容
	String content = sysSmsTemplate.getTemplateContent();
	if(map!=null) {
		for (Map.Entry<String, String> entry : map.entrySet()) {
			String str = "${" + entry.getKey() + "}";
			title = title.replace(str, entry.getValue());
			content = content.replace(str, entry.getValue());
		}
	}
	SysAnnouncement announcement = new SysAnnouncement();
	announcement.setTitile(title);
	announcement.setMsgContent(content);
	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));
	announcement.setBusId(busId);
	announcement.setBusType(busType);
	announcement.setOpenType(SysAnnmentTypeEnum.getByType(busType).getOpenType());
	announcement.setOpenPage(SysAnnmentTypeEnum.getByType(busType).getOpenPage());
	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());
		}
	}
}
示例22
@Override
public List<SysMessageTemplate> selectByCode(String code) {
    return sysMessageTemplateMapper.selectByCode(code);
}
示例23
@Select("SELECT * FROM SYS_SMS_TEMPLATE WHERE TEMPLATE_CODE = #{code}")
List<SysMessageTemplate> selectByCode(String code);
示例24
@Override
public void sendSysAnnouncement(String fromUser, String toUser,String title,Map<String, String> map, String templateCode) {
	List<SysMessageTemplate> sysSmsTemplates = sysMessageTemplateService.selectByCode(templateCode);
       if(sysSmsTemplates==null||sysSmsTemplates.size()==0){
           throw new JeecgBootException("消息模板不存在，模板编码："+templateCode);
       }
	SysMessageTemplate sysSmsTemplate = sysSmsTemplates.get(0);
	//模板标题
	title = title==null?sysSmsTemplate.getTemplateName():title;
	//模板内容
	String content = sysSmsTemplate.getTemplateContent();
	if(map!=null) {
		for (Map.Entry<String, String> entry : map.entrySet()) {
			String str = "${" + entry.getKey() + "}";
			title = title.replace(str, entry.getValue());
			content = content.replace(str, entry.getValue());
		}
	}

	SysAnnouncement announcement = new SysAnnouncement();
	announcement.setTitile(title);
	announcement.setMsgContent(content);
	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(WebsocketConst.MSG_CMD, WebsocketConst.CMD_USER);
			obj.put(WebsocketConst.MSG_USER_ID, sysUser.getId());
			obj.put(WebsocketConst.MSG_ID, announcement.getId());
			obj.put(WebsocketConst.MSG_TXT, announcement.getTitile());
			webSocket.sendOneMessage(sysUser.getId(), obj.toJSONString());
		}
	}
}
示例25
@Override
public void sendSysAnnouncement(String fromUser, String toUser, String title, Map<String, String> map, String templateCode, String busType, String busId) {
	List<SysMessageTemplate> sysSmsTemplates = sysMessageTemplateService.selectByCode(templateCode);
	if(sysSmsTemplates==null||sysSmsTemplates.size()==0){
		throw new JeecgBootException("消息模板不存在，模板编码："+templateCode);
	}
	SysMessageTemplate sysSmsTemplate = sysSmsTemplates.get(0);
	//模板标题
	title = title==null?sysSmsTemplate.getTemplateName():title;
	//模板内容
	String content = sysSmsTemplate.getTemplateContent();
	if(map!=null) {
		for (Map.Entry<String, String> entry : map.entrySet()) {
			String str = "${" + entry.getKey() + "}";
			title = title.replace(str, entry.getValue());
			content = content.replace(str, entry.getValue());
		}
	}
	SysAnnouncement announcement = new SysAnnouncement();
	announcement.setTitile(title);
	announcement.setMsgContent(content);
	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));
	announcement.setBusId(busId);
	announcement.setBusType(busType);
	announcement.setOpenType(SysAnnmentTypeEnum.getByType(busType).getOpenType());
	announcement.setOpenPage(SysAnnmentTypeEnum.getByType(busType).getOpenPage());
	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(WebsocketConst.MSG_CMD, WebsocketConst.CMD_USER);
			obj.put(WebsocketConst.MSG_USER_ID, sysUser.getId());
			obj.put(WebsocketConst.MSG_ID, announcement.getId());
			obj.put(WebsocketConst.MSG_TXT, announcement.getTitile());
			webSocket.sendOneMessage(sysUser.getId(), obj.toJSONString());
		}
	}
}
示例26
/**
 * 分页列表查询
 * 
 * @param sysMessageTemplate
 * @param pageNo
 * @param pageSize
 * @param req
 * @return
 */
@GetMapping(value = "/list")
public Result<?> queryPageList(SysMessageTemplate sysMessageTemplate, @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo,
		@RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize, HttpServletRequest req) {
	QueryWrapper<SysMessageTemplate> queryWrapper = QueryGenerator.initQueryWrapper(sysMessageTemplate, req.getParameterMap());
	Page<SysMessageTemplate> page = new Page<SysMessageTemplate>(pageNo, pageSize);
	IPage<SysMessageTemplate> pageList = sysMessageTemplateService.page(page, queryWrapper);
       return Result.ok(pageList);
}
示例27
/**
 * 分页列表查询
 * 
 * @param sysMessageTemplate
 * @param pageNo
 * @param pageSize
 * @param req
 * @return
 */
@GetMapping(value = "/list")
public Result<?> queryPageList(SysMessageTemplate sysMessageTemplate, @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo,
		@RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize, HttpServletRequest req) {
	QueryWrapper<SysMessageTemplate> queryWrapper = QueryGenerator.initQueryWrapper(sysMessageTemplate, req.getParameterMap());
	Page<SysMessageTemplate> page = new Page<SysMessageTemplate>(pageNo, pageSize);
	IPage<SysMessageTemplate> pageList = sysMessageTemplateService.page(page, queryWrapper);
       return Result.ok(pageList);
}
示例28
/**
 * 分页列表查询
 * 
 * @param sysMessageTemplate
 * @param pageNo
 * @param pageSize
 * @param req
 * @return
 */
@GetMapping(value = "/list")
public Result<?> queryPageList(SysMessageTemplate sysMessageTemplate, @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo,
		@RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize, HttpServletRequest req) {
	QueryWrapper<SysMessageTemplate> queryWrapper = QueryGenerator.initQueryWrapper(sysMessageTemplate, req.getParameterMap());
	Page<SysMessageTemplate> page = new Page<SysMessageTemplate>(pageNo, pageSize);
	IPage<SysMessageTemplate> pageList = sysMessageTemplateService.page(page, queryWrapper);
       return Result.ok(pageList);
}
示例29
/**
 * 分页列表查询
 * 
 * @param sysMessageTemplate
 * @param pageNo
 * @param pageSize
 * @param req
 * @return
 */
@GetMapping(value = "/list")
public Result<?> queryPageList(SysMessageTemplate sysMessageTemplate, @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo,
		@RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize, HttpServletRequest req) {
	QueryWrapper<SysMessageTemplate> queryWrapper = QueryGenerator.initQueryWrapper(sysMessageTemplate, req.getParameterMap());
	Page<SysMessageTemplate> page = new Page<SysMessageTemplate>(pageNo, pageSize);
	IPage<SysMessageTemplate> pageList = sysMessageTemplateService.page(page, queryWrapper);
       return Result.ok(pageList);
}
示例30
/**
 * 添加
 * 
 * @param sysMessageTemplate
 * @return
 */
@PostMapping(value = "/add")
public Result<?> add(@RequestBody SysMessageTemplate sysMessageTemplate) {
	sysMessageTemplateService.save(sysMessageTemplate);
       return Result.ok("添加成功！");
}