1.删除无用代码

amos-boot-system-jxiop/amos-boot-module-jxiop-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/emqx/PersonYardMessage.java

 package com.yeejoin.amos.boot.module.jxiop.biz.emqx;
 
 import com.alibaba.fastjson.JSON;
-import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
-import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
-import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
 import com.yeejoin.amos.boot.module.jxiop.api.entity.PersonBasic;
 import com.yeejoin.amos.boot.module.jxiop.api.mapper.PersonBasicMapper;
-import com.yeejoin.amos.boot.module.jxiop.api.mapper.StationBasicMapper;
-import com.yeejoin.amos.boot.module.jxiop.biz.service.impl.PersonBasicServiceImpl;
-import com.yeejoin.amos.component.robot.AmosRequestContext;
 import lombok.extern.slf4j.Slf4j;
 import org.eclipse.paho.client.mqttv3.MqttException;
 import org.eclipse.paho.client.mqttv3.MqttMessage;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.scheduling.annotation.EnableScheduling;
 import org.springframework.stereotype.Component;
 import org.typroject.tyboot.component.emq.EmqKeeper;
 import org.typroject.tyboot.component.emq.EmqxListener;
-import org.typroject.tyboot.core.foundation.context.RequestContext;
 
 import javax.annotation.PostConstruct;
-import java.util.List;
-import java.util.Map;
 import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.LinkedBlockingQueue;
 
 @Component
-@EnableScheduling
 @Slf4j
 public class PersonYardMessage extends EmqxListener {
-    @Autowired
-    private AmosRequestContext amosAuth;
 
     @Autowired
     protected EmqKeeper emqKeeper;

amos-boot-system-jxiop/amos-boot-module-jxiop-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/emqx/StationYardMessage.java

@@ -3,15 +3,11 @@ package com.yeejoin.amos.boot.module.jxiop.biz.emqx;
 import com.alibaba.fastjson.JSONArray;
 import com.yeejoin.amos.boot.module.jxiop.api.mapper.StationBasicMapper;
 import lombok.extern.slf4j.Slf4j;
-import com.yeejoin.amos.component.robot.AmosRequestContext;
 import org.eclipse.paho.client.mqttv3.MqttMessage;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.scheduling.annotation.EnableScheduling;
 import org.springframework.stereotype.Component;
 import org.typroject.tyboot.component.emq.EmqKeeper;
 import org.typroject.tyboot.component.emq.EmqxListener;
-import org.typroject.tyboot.core.foundation.context.RequestContext;
 
 import javax.annotation.PostConstruct;
 import java.util.List;
@@ -20,12 +16,9 @@ import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.LinkedBlockingQueue;
 
 @Component
-@EnableScheduling
 @Slf4j
 public class StationYardMessage extends EmqxListener {
 
-    @Autowired
-    private AmosRequestContext amosAuth;
 
     @Autowired
     protected EmqKeeper emqKeeper;
@@ -34,7 +27,9 @@ public class StationYardMessage extends EmqxListener {
     private StationBasicMapper stationBasicMapper;
 
 
-    // 江西电建接收红黄绿码主题
+    /**
+     * 江西电建接收红黄绿码主题
+     */
     private static final String JXIOP_STATION_YARD = "jxIop/station/yard";
 
     private static final BlockingQueue<List<Map<String, String>>> blockingQueue = new LinkedBlockingQueue<List<Map<String, String>>>();