添加定时任务

meter-reading-sishui/read-sqlSever/src/main/java/com/zcxk/service/SyncService.java

@@ -55,33 +55,37 @@ public class SyncService {
         if(needAddWaterMeter.size()>0){
             log.info("增加新增泗水水表");
             sendDao.insertDeviceInfo(needAddWaterMeter);
-            needAddWaterMeter.forEach(device->{
-                Building building = sendDao.getBuilding(device.getBuildingId());
-                //2、同步设备维度关系
-                DeviceDimension deviceDimension = new DeviceDimension();
-                deviceDimension.setDeviceId(device.getId());
-                if (building != null) {
-                    deviceDimension.setProvince(String.valueOf(building.getProvince()));
-                    deviceDimension.setCity(String.valueOf(building.getCity()));
-                    deviceDimension.setRegion(String.valueOf(building.getRegion()));
-                    deviceDimension.setCommunity(String.valueOf(building.getCommunity()));
-                    deviceDimension.setBuilding(String.valueOf(building.getId()));
-                }
-                deviceDimension.setFloor(String.valueOf(device.getFloor()));
-                deviceDimension.setDevice(device.getDeviceNo());
-                deviceDimension.setCustomer(String.valueOf(device.getCustomerId()));
-                deviceDimension.setStatus(1);
-                deviceDimension.setCreateBy("system");
-                deviceDimension.setUpdateBy("system");
-                deviceDimension.setDateCreate(LocalDateTime.now());
-                deviceDimension.setDateUpdate(LocalDateTime.now());
-                sendDao.insertSelective(deviceDimension);
-            });
+            //添加维度信息
+            setDeviceDimernsionInfo(needAddWaterMeter);
 
         }
 
 
 
+    }
+    private void setDeviceDimernsionInfo(List<Device>needAddWaterMeter){
+        needAddWaterMeter.forEach(device->{
+            Building building = sendDao.getBuilding(device.getBuildingId());
+            //2、同步设备维度关系
+            DeviceDimension deviceDimension = new DeviceDimension();
+            deviceDimension.setDeviceId(device.getId());
+            if (building != null) {
+                deviceDimension.setProvince(String.valueOf(building.getProvince()));
+                deviceDimension.setCity(String.valueOf(building.getCity()));
+                deviceDimension.setRegion(String.valueOf(building.getRegion()));
+                deviceDimension.setCommunity(String.valueOf(building.getCommunity()));
+                deviceDimension.setBuilding(String.valueOf(building.getId()));
+            }
+            deviceDimension.setFloor(String.valueOf(device.getFloor()));
+            deviceDimension.setDevice(device.getDeviceNo());
+            deviceDimension.setCustomer(String.valueOf(device.getCustomerId()));
+            deviceDimension.setStatus(1);
+            deviceDimension.setCreateBy("system");
+            deviceDimension.setUpdateBy("system");
+            deviceDimension.setDateCreate(LocalDateTime.now());
+            deviceDimension.setDateUpdate(LocalDateTime.now());
+            sendDao.insertSelective(deviceDimension);
+        });
     }
     private void setNeddWaterMeters(List<Map<String, Object>> meterInfor, List<Device>needAddWaterMeter){
         List<DeviceType> deviceTypes = sendDao.selectDeviceType();