增加消息发送

jxjy-system/src/main/java/com/jxjy/system/schedule/MessageSchedule.java

@@ -5,9 +5,11 @@ import com.alibaba.fastjson.JSONObject;
 import com.jxjy.system.service.MessageRecordService;
 import com.jxjy.system.service.MessageService;
 import com.jxjy.system.service.PersonService;
+import com.jxjy.system.service.RecruitService;
 import com.jxjy.system.util.weixin.TencentMessageUtil;
 import data.system.Message;
 import data.system.MessageRecord;
+import data.system.Recruit;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.data.redis.core.StringRedisTemplate;
@@ -35,6 +37,9 @@ public class MessageSchedule {
     @Autowired
     private StringRedisTemplate stringRedisTemplate;
 
+    @Autowired
+    private RecruitService recruitService;
+
     @Value("${weixin.appid}")
     String AppId;
     @Value("${weixin.secret}")
@@ -58,6 +63,7 @@ public class MessageSchedule {
 
         if(message!=null){
 
+            Recruit recruit = recruitService.getDetails(message.getRecruitId());
 
             List<data.system.Person> personList = personService.getRecruitMessageList(message.getRecruitId());
 
@@ -76,12 +82,12 @@ public class MessageSchedule {
 
                 //发送微信消息
                 JSONObject json = new JSONObject();
-                json.put("thing6", JSONObject.parseObject("{'value':'预支工资提醒'}"));
-                json.put("thing2", JSONObject.parseObject("{'value':'预支已发放'}"));
-                json.put("time9", JSONObject.parseObject("{'value':'" + DateUtil.now() + "'}"));
-                json.put("thing5", JSONObject.parseObject("{'value':'点击查看详情'}"));
+                json.put("thing1", JSONObject.parseObject("{'value':'"+recruit.getOrg().getName()+"'}"));
+                json.put("thing2", JSONObject.parseObject("{'value':'"+recruit.getName()+"'}"));
+                //json.put("time9", JSONObject.parseObject("{'value':'" + DateUtil.now() + "'}"));
+                json.put("thing3", JSONObject.parseObject("{'value':'点击查看详情'}"));
                 //发送消息并减少数量
-                //TencentMessageUtil.send(stringRedisTemplate, AppId, Secret, MPTId, "/pages/home/advanceLog/index", MMP, person.getOpenId(), json);
+                TencentMessageUtil.send(stringRedisTemplate, AppId, Secret, MPTId, "/pages/notice/index", MMP, person.getOpenId(), json);
             }
 
             if(personList.size()==0){

jxjy-system/src/main/java/com/jxjy/system/service/impl/RecruitServiceImpl.java

@@ -205,7 +205,9 @@ public class RecruitServiceImpl extends ServiceImpl<RecruitMapper, Recruit> impl
 
             Industry industry = industryService.getDetails(recruit.getIndustryId());
 
+            if(industry!=null){
                 recruit.setIndustryCode(industry.getCode());
+            }
 
 
         }catch (Exception e){