新派遣通知

amos-boot-module/amos-boot-module-biz/amos-boot-module-tzs-biz/src/main/java/com/yeejoin/amos/boot/module/tzs/biz/service/impl/DispatchTaskServiceImpl.java

 package com.yeejoin.amos.boot.module.tzs.biz.service.impl;
 
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
@@ -37,17 +38,23 @@ import com.yeejoin.amos.boot.module.tzs.api.service.IDispatchTaskService;
 import com.yeejoin.amos.boot.module.tzs.api.service.IMaintenanceUnitService;
 import com.yeejoin.amos.boot.module.tzs.api.service.IRescueStationService;
 import com.yeejoin.amos.boot.module.tzs.api.service.IUseUnitService;
+import com.yeejoin.amos.boot.module.tzs.biz.controller.WechatController;
 import com.yeejoin.amos.boot.module.tzs.biz.utils.BeanDtoVoUtils;
 import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
 import org.apache.commons.lang3.StringUtils;
+import org.eclipse.paho.client.mqttv3.MqttException;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
+import org.typroject.tyboot.component.emq.EmqKeeper;
 import org.typroject.tyboot.core.rdbms.service.BaseService;
 import org.typroject.tyboot.core.restful.exception.instance.BadRequest;
 import org.typroject.tyboot.core.restful.utils.ResponseHelper;
 
+import java.io.UnsupportedEncodingException;
 import java.text.SimpleDateFormat;
 import java.util.Date;
 import java.util.HashMap;
@@ -63,7 +70,7 @@ import java.util.Map;
 @Service
 public class DispatchTaskServiceImpl extends BaseService<DispatchTaskDto,DispatchTask,DispatchTaskMapper> implements IDispatchTaskService {
 
-
+    private final Logger logger = LoggerFactory.getLogger(DispatchTaskServiceImpl.class);
     @Autowired
     DispatchPaperServiceImpl dispatchPaperServiceImpl;
 
@@ -106,6 +113,9 @@ public class DispatchTaskServiceImpl extends BaseService<DispatchTaskDto,Dispatc
     @Autowired
     WechatServiceImpl wechatService;
 
+    @Autowired
+    private EmqKeeper emqKeeper;
+
     @Value("${tzs.wechat.tempId.kr}")
     private String KRJY_TEMPID;
 
@@ -124,6 +134,10 @@ public class DispatchTaskServiceImpl extends BaseService<DispatchTaskDto,Dispatc
     @Value("${tzs.wechat.url.ts}")
     private String TS_URL;
 
+    @Value("${mqtt.topic.task.newtask}")
+    private String newTaskTopic;
+
+
     /**
      * 分页查询
      */
@@ -606,6 +620,17 @@ public class DispatchTaskServiceImpl extends BaseService<DispatchTaskDto,Dispatc
                 WechatMessageDto dto = this.getWechatMessageDtoByDispatchTaskDto(dispatchTaskDto);
                 wechatService.sendWechatModelMessage(temp.getOpenId() ,  dto);
             }
+            // mqtt 通知新派遣
+            JSONObject jsonObject = new JSONObject();
+            jsonObject.put("taskId",dispatchTaskDto.getSequenceNbr());
+            try {
+                emqKeeper.getMqttClient().publish(newTaskTopic, jsonObject.toString().getBytes("UTF-8"), 1, false);
+            } catch (MqttException e) {
+                logger.error("mqtt发送失败" +jsonObject );
+            } catch (UnsupportedEncodingException e) {
+                logger.error("mqtt发送失败" +jsonObject );
+            }
+
         }
         return flag;
     }

amos-boot-system-tzs/src/main/resources/application-dev.properties

@@ -59,6 +59,7 @@ tzs.wechat.url.wx=tzs.yeeamos.com/repairPersondetail.html
 tzs.wechat.tempId.ts=SLjmNJoCNLC3FBcYzWzR-u3el0kqXf8WMTmzw8dAQm4
 tzs.wechat.url.ts=tzs.yeeamos.com/persondetail.html
 
+mqtt.topic.task.newtask=tzs-task-newtask
 
 mqtt.topic.task.personinfo=tzs-task-personinfo