消息推送定时服务

src/main/java/com/hz/employmentsite/services/impl/WechatServiceImpl.java

@@ -119,6 +119,12 @@ public class WechatServiceImpl implements WechatService {
 
             wxMessagestatusMapper.insert(wxMessagestatus);
         }
+        else{
+            wxMessagestatus.setContent(sendData.toString());
+            wxMessagestatus.setModifyTime(new Date());
+
+            wxMessagestatusMapper.updateByPrimaryKey(wxMessagestatus);
+        }
 
         try {
             sendMsg(openId, templateId, url, sendData);

src/main/java/com/hz/employmentsite/services/impl/jobUserManager/RecommendMgtServiceImpl.java

@@ -121,7 +121,7 @@ public class RecommendMgtServiceImpl implements RecommendMgtService {
         sendCompany();
     }
 
-    private void sendUser(){
+    private void sendUser() {
         List<HashMap<String, Object>> toUserList = recommendMgtCQuery.getCompanypostToUsermessageList();
 
         WxMessagetempsetting toUserTemp = wechatService.getWxMessagetempsettingList().stream().filter(it -> it.getTemplateNo().equals("toUser")).findFirst().orElse(null);
@@ -141,7 +141,7 @@ public class RecommendMgtServiceImpl implements RecommendMgtService {
                         });
 
 
-                        boolean result = wechatService.sendMsg(item.get("userOpenId").toString(), recommendmgtid, toUserTemp.getUrl(), toUserTemp.getTemplateId(), data);
+                        boolean result = wechatService.sendMsg(item.get("userOpenId").toString(), recommendmgtid, toUserTemp.getUrl() + "?recommendmgtid=" + recommendmgtid, toUserTemp.getTemplateId(), data);
 
                         if (result) {
                             pcRecommendMgt.setIsSendUser(true);
@@ -155,7 +155,7 @@ public class RecommendMgtServiceImpl implements RecommendMgtService {
         }
     }
 
-    private void sendCompany(){
+    private void sendCompany() {
         List<HashMap<String, Object>> toCompanyList = recommendMgtCQuery.getUserhuntpostToCompanymessageList();
 
         WxMessagetempsetting toCompanyTemp = wechatService.getWxMessagetempsettingList().stream().filter(it -> it.getTemplateNo().equals("toCompany")).findFirst().orElse(null);
@@ -175,7 +175,7 @@ public class RecommendMgtServiceImpl implements RecommendMgtService {
                         });
 
 
-                        boolean result = wechatService.sendMsg(item.get("companyOpenId").toString(), recommendmgtid, toCompanyTemp.getUrl(), toCompanyTemp.getTemplateId(), data);
+                        boolean result = wechatService.sendMsg(item.get("companyOpenId").toString(), recommendmgtid, toCompanyTemp.getUrl() + "?recommendmgtid=" + recommendmgtid, toCompanyTemp.getTemplateId(), data);
 
                         if (result) {
                             pcRecommendMgt.setIsSendUser(true);