添加打印日志，排查mqtt设备消息偶尔丢失的问题

data-transfer/data-transfer-biz/src/main/java/com/usky/transfer/service/impl/QueryInfluxdbDataServiceImpl.java

@@ -144,6 +144,7 @@ public class QueryInfluxdbDataServiceImpl extends AbstractCrudService<QueryInflu
             String productCode = writeVO.getProductCode();
             String deviceUUId = writeVO.getDeviceUUId();
             String deviceId = tags.get("device_id");
+            log.info("sendDeviceDataToMQ "+deviceId+" start222");
 
             //判断上报数据对应产品是否注册，如未注册则为非法
             Map<String,ProductMapVO> productMapList = dmpProductService.getProductMap();

data-transfer/data-transfer-biz/src/main/java/com/usky/transfer/service/mqtt/datacollector/DataCollector.java

@@ -8,6 +8,7 @@ import com.usky.transfer.service.QueryInfluxdbDataService;
 import com.usky.transfer.service.mqtt.MqttStrategy;
 import com.usky.transfer.service.rocketmq.MyProducer;
 import com.usky.transfer.service.vo.MqttBaseVO;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
@@ -19,6 +20,7 @@ import java.util.Map;
  * @author zyj
  * @date 2022/12/6 15:07
  */
+@Slf4j
 @Service("dataCollector")
 public class DataCollector implements MqttStrategy {
     @Resource
@@ -35,6 +37,7 @@ public class DataCollector implements MqttStrategy {
         String deviceId = map_data.get("device_id").toString();
 
         tags.put("device_id",deviceId);
+        log.info("disposeMessage "+deviceId+" start111");
 
         Object met = JSONObject.toJSONString(map_data.get("metrics"));
         JSONObject metrics = JSON.parseObject(met.toString());
@@ -49,9 +52,7 @@ public class DataCollector implements MqttStrategy {
         deviceDataWriteVO.setTags(tags);
         deviceDataWriteVO.setMetrics(metrics);
 
-        if(deviceId.equals("00003320010017") || deviceId.equals("862335058368264")){
-            queryInfluxdbDataService.sendDeviceDataToMQ(deviceDataWriteVO);
-        }
+        queryInfluxdbDataService.sendDeviceDataToMQ(deviceDataWriteVO);
 
         return null;
     }