打印日志，测试mqtt消息部分丢失的问题

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

@@ -242,8 +242,10 @@ public class QueryInfluxdbDataServiceImpl extends AbstractCrudService<QueryInflu
             dataInfo.setProductCode(productCode);
             dataInfo.setDeviceUUId(deviceUUId);
             dataInfo.setTimestamp(writeVO.getTimestamp());
+            log.info("推送tsdb "+JSONArray.toJSON(dataInfo).toString()+" start");
 
             myProducer.sendMessage("data-tsdb", JSONArray.toJSON(dataInfo).toString());
+            log.info("推送tsdb "+JSONArray.toJSON(dataInfo).toString()+" end");
         }
 
         rec_map.put("code",200);

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

@@ -49,7 +49,9 @@ public class DataCollector implements MqttStrategy {
         deviceDataWriteVO.setTags(tags);
         deviceDataWriteVO.setMetrics(metrics);
 
-        queryInfluxdbDataService.sendDeviceDataToMQ(deviceDataWriteVO);
+        if(deviceId.equals("00003320010017") || deviceId.equals("862335058368264")){
+            queryInfluxdbDataService.sendDeviceDataToMQ(deviceDataWriteVO);
+        }
 
         return null;
     }