Selaa lähdekoodia

优化data-tranfer服务模块新增设备时,设备状态表deviceUuid字段值的录入

james 1 kuukausi sitten
vanhempi
commit
2f2d3a2b42

+ 5 - 0
data-transfer/data-transfer-biz/src/main/java/com/usky/transfer/domain/DmpDeviceStatus.java

@@ -57,5 +57,10 @@ public class DmpDeviceStatus implements Serializable {
      */
     private String productCode;
 
+    /**
+     * 设备uuid
+     */
+    private String deviceUuid;
+
 
 }

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

@@ -190,6 +190,7 @@ public class QueryInfluxdbDataServiceImpl extends AbstractCrudService<QueryInflu
                 dmpDeviceStatus.setDeviceStatus(2);
                 dmpDeviceStatus.setLastOfflineTime(LocalDateTime.now());
                 dmpDeviceStatus.setProductCode(dmpDeviceInfo.getProductCode());
+                dmpDeviceStatus.setDeviceUuid(deviceUUId);
                 dmpDeviceStatusService.save(dmpDeviceStatus);
 
                 deviceMapList = dmpProductService.getDeviceMap(productCode);
@@ -223,6 +224,7 @@ public class QueryInfluxdbDataServiceImpl extends AbstractCrudService<QueryInflu
                     dmpDeviceStatus.setDeviceStatus(2);
                     dmpDeviceStatus.setLastOfflineTime(LocalDateTime.now());
                     dmpDeviceStatus.setProductCode(dmpDeviceInfo.getProductCode());
+                    dmpDeviceStatus.setDeviceUuid(deviceUUId);
                     dmpDeviceStatusService.save(dmpDeviceStatus);
 
                     deviceMapList = dmpProductService.getDeviceMap(productCode);

+ 2 - 0
data-transfer/data-transfer-biz/src/main/java/com/usky/transfer/service/mqtt/add/Add.java

@@ -81,6 +81,7 @@ public class Add implements MqttStrategy {
             dmpDeviceStatus.setDeviceStatus(2);
             dmpDeviceStatus.setLastOfflineTime(LocalDateTime.now());
             dmpDeviceStatus.setProductCode(dmpDeviceInfo.getProductCode());
+            dmpDeviceStatus.setDeviceUuid(dmpDeviceInfo.getDeviceUuid());
             dmpDeviceStatusService.save(dmpDeviceStatus);
 
             dmpProductService.deleteDeviceCache(productCode);
@@ -111,6 +112,7 @@ public class Add implements MqttStrategy {
                 dmpDeviceStatus.setDeviceStatus(2);
                 dmpDeviceStatus.setLastOfflineTime(LocalDateTime.now());
                 dmpDeviceStatus.setProductCode(dmpDeviceInfo.getProductCode());
+                dmpDeviceStatus.setDeviceUuid(dmpDeviceInfo.getDeviceUuid());
                 dmpDeviceStatusService.save(dmpDeviceStatus);
 
                 dmpProductService.deleteDeviceCache(productCode);