|
@@ -258,66 +258,69 @@ public class NewsServiceImpl extends MPJBaseServiceImpl<NewsMapper, News> implem
|
|
|
|
|
|
@Override
|
|
|
public boolean SendMessage(Long id) {
|
|
|
- News news = newsMapper.selectById(id);
|
|
|
- if (news.getSendRange() == 1) {
|
|
|
- List<User> userList = userMapper.selectList(Wrappers.<User>query().lambda().isNotNull(User::getOpenId).ne(User::getOpenId,""));
|
|
|
- if(userList.size()>0) {
|
|
|
- for (User user : userList) {
|
|
|
- WeChatSendMessageDto weChatSendMessageDto = new WeChatSendMessageDto();
|
|
|
- weChatSendMessageDto.setUserId(user.getOpenId());
|
|
|
- weChatSendMessageDto.setTemplateId("sHsmz7LRj7HLd7GSTS3r2uKMhE2f1iDAW15RqSK_6KM");
|
|
|
- weChatSendMessageDto.setUrl("https://zhxy.cqtlzjzx.com/app/#/pages/message/notice/detail?id="+id);
|
|
|
- weChatSendMessageDto.setMsgId(id.toString());
|
|
|
- JSONObject data = new JSONObject();
|
|
|
-
|
|
|
- JSONObject data1 = new JSONObject();
|
|
|
- data1.put("value", news.getFullHead());
|
|
|
- data.put("thing2", data1);
|
|
|
-
|
|
|
- JSONObject data2 = new JSONObject();
|
|
|
- data2.put("value", news.getAuthorName());
|
|
|
- data.put("phrase5", data2);
|
|
|
-
|
|
|
- JSONObject data3 = new JSONObject();
|
|
|
- data3.put("value", LocalDateTimeUtil.format(news.getReleaseTime(),"yyyy-MM-dd HH:mm:ss") );
|
|
|
- data.put("time3", data3);
|
|
|
- weChatSendMessageDto.setContent(data);
|
|
|
- weChatService.sendTemplateMessage(weChatSendMessageDto);
|
|
|
+ try {
|
|
|
+ News news = newsMapper.selectById(id);
|
|
|
+ if (news.getSendRange() == 1) {
|
|
|
+ List<User> userList = userMapper.selectList(Wrappers.<User>query().lambda().isNotNull(User::getOpenId).ne(User::getOpenId, ""));
|
|
|
+ if (userList.size() > 0) {
|
|
|
+ for (User user : userList) {
|
|
|
+ WeChatSendMessageDto weChatSendMessageDto = new WeChatSendMessageDto();
|
|
|
+ weChatSendMessageDto.setUserId(user.getOpenId());
|
|
|
+ weChatSendMessageDto.setTemplateId("sHsmz7LRj7HLd7GSTS3r2uKMhE2f1iDAW15RqSK_6KM");
|
|
|
+ weChatSendMessageDto.setUrl("https://zhxy.cqtlzjzx.com/app/#/pages/message/notice/detail?id=" + id);
|
|
|
+ weChatSendMessageDto.setMsgId(id.toString());
|
|
|
+ JSONObject data = new JSONObject();
|
|
|
+
|
|
|
+ JSONObject data1 = new JSONObject();
|
|
|
+ data1.put("value", news.getFullHead());
|
|
|
+ data.put("thing2", data1);
|
|
|
+
|
|
|
+ JSONObject data2 = new JSONObject();
|
|
|
+ data2.put("value", news.getAuthorName());
|
|
|
+ data.put("phrase5", data2);
|
|
|
+
|
|
|
+ JSONObject data3 = new JSONObject();
|
|
|
+ data3.put("value", LocalDateTimeUtil.format(news.getReleaseTime(), "yyyy-MM-dd HH:mm:ss"));
|
|
|
+ data.put("time3", data3);
|
|
|
+ weChatSendMessageDto.setContent(data);
|
|
|
+ weChatService.sendTemplateMessage(weChatSendMessageDto);
|
|
|
+ }
|
|
|
}
|
|
|
- }
|
|
|
- } else {
|
|
|
- List<NewsRelationVo> newsRelationVoList = newsRelationMapper.selectJoinList(NewsRelationVo.class,
|
|
|
- new MPJLambdaWrapper<NewsRelation>().distinct()
|
|
|
- .eq(NewsRelation::getNewsId, id)
|
|
|
- .select(NewsRelation.class, x -> VoToColumnUtil.fieldsToColumns(NewsRelationVo.class).contains(x.getProperty()))
|
|
|
- .innerJoin(User.class, onWrapper -> onWrapper.eq(NewsRelation::getUserId, User::getId).isNotNull(User::getOpenId).ne(User::getOpenId,""))
|
|
|
- .selectAs(User::getOpenId, NewsRelationVo::getUserName)
|
|
|
- );
|
|
|
- if (newsRelationVoList.size() > 0) {
|
|
|
- for (NewsRelationVo newsRelationVo : newsRelationVoList) {
|
|
|
- WeChatSendMessageDto weChatSendMessageDto = new WeChatSendMessageDto();
|
|
|
- weChatSendMessageDto.setUserId(newsRelationVo.getUserName());
|
|
|
- weChatSendMessageDto.setTemplateId("sHsmz7LRj7HLd7GSTS3r2uKMhE2f1iDAW15RqSK_6KM");
|
|
|
- weChatSendMessageDto.setUrl("https://zhxy.cqtlzjzx.com/app/#/pages/message/notice/detail?id="+id);
|
|
|
- weChatSendMessageDto.setMsgId(id.toString());
|
|
|
- JSONObject data = new JSONObject();
|
|
|
-
|
|
|
- JSONObject data1 = new JSONObject();
|
|
|
- data1.put("value", news.getFullHead());
|
|
|
- data.put("thing2", data1);
|
|
|
-
|
|
|
- JSONObject data2 = new JSONObject();
|
|
|
- data2.put("value", news.getAuthorName());
|
|
|
- data.put("phrase5", data2);
|
|
|
-
|
|
|
- JSONObject data3 = new JSONObject();
|
|
|
- data3.put("value", LocalDateTimeUtil.format(news.getReleaseTime(),"yyyy-MM-dd HH:mm:ss") );
|
|
|
- data.put("time3", data3);
|
|
|
- weChatSendMessageDto.setContent(data);
|
|
|
- weChatService.sendTemplateMessage(weChatSendMessageDto);
|
|
|
+ } else {
|
|
|
+ List<NewsRelationVo> newsRelationVoList = newsRelationMapper.selectJoinList(NewsRelationVo.class,
|
|
|
+ new MPJLambdaWrapper<NewsRelation>().distinct()
|
|
|
+ .eq(NewsRelation::getNewsId, id)
|
|
|
+ .select(NewsRelation.class, x -> VoToColumnUtil.fieldsToColumns(NewsRelationVo.class).contains(x.getProperty()))
|
|
|
+ .innerJoin(User.class, onWrapper -> onWrapper.eq(NewsRelation::getUserId, User::getId).isNotNull(User::getOpenId).ne(User::getOpenId, ""))
|
|
|
+ .selectAs(User::getOpenId, NewsRelationVo::getUserName)
|
|
|
+ );
|
|
|
+ if (newsRelationVoList.size() > 0) {
|
|
|
+ for (NewsRelationVo newsRelationVo : newsRelationVoList) {
|
|
|
+ WeChatSendMessageDto weChatSendMessageDto = new WeChatSendMessageDto();
|
|
|
+ weChatSendMessageDto.setUserId(newsRelationVo.getUserName());
|
|
|
+ weChatSendMessageDto.setTemplateId("sHsmz7LRj7HLd7GSTS3r2uKMhE2f1iDAW15RqSK_6KM");
|
|
|
+ weChatSendMessageDto.setUrl("https://zhxy.cqtlzjzx.com/app/#/pages/message/notice/detail?id=" + id);
|
|
|
+ weChatSendMessageDto.setMsgId(id.toString());
|
|
|
+ JSONObject data = new JSONObject();
|
|
|
+
|
|
|
+ JSONObject data1 = new JSONObject();
|
|
|
+ data1.put("value", news.getFullHead());
|
|
|
+ data.put("thing2", data1);
|
|
|
+
|
|
|
+ JSONObject data2 = new JSONObject();
|
|
|
+ data2.put("value", news.getAuthorName());
|
|
|
+ data.put("phrase5", data2);
|
|
|
+
|
|
|
+ JSONObject data3 = new JSONObject();
|
|
|
+ data3.put("value", LocalDateTimeUtil.format(news.getReleaseTime(), "yyyy-MM-dd HH:mm:ss"));
|
|
|
+ data.put("time3", data3);
|
|
|
+ weChatSendMessageDto.setContent(data);
|
|
|
+ weChatService.sendTemplateMessage(weChatSendMessageDto);
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
+ catch(Exception ex) {}
|
|
|
|
|
|
return true;
|
|
|
}
|