فهرست منبع

同步服务 修改

zhanghao 4 ماه پیش
والد
کامیت
4314d33eef
39فایلهای تغییر یافته به همراه856 افزوده شده و 393 حذف شده
  1. 2 1
      src/main/java/com/sckj/project/service/car/ILargeCarService.java
  2. 6 2
      src/main/java/com/sckj/project/service/impl/car/LargeCarServiceImpl.java
  3. 6 2
      src/main/java/com/sckj/project/service/impl/logistics/LargePlatLogisticsServiceImpl.java
  4. 6 2
      src/main/java/com/sckj/project/service/impl/service/LargePlatAccessServiceImpl.java
  5. 7 2
      src/main/java/com/sckj/project/service/impl/service/LargePlatBasicsCompanyServiceImpl.java
  6. 7 2
      src/main/java/com/sckj/project/service/impl/service/LargePlatBasicsServerServiceImpl.java
  7. 7 2
      src/main/java/com/sckj/project/service/impl/service/LargePlatBasicsServiceImpl.java
  8. 7 2
      src/main/java/com/sckj/project/service/impl/service/LargePlatEmployeeHealthServiceImpl.java
  9. 7 2
      src/main/java/com/sckj/project/service/impl/service/LargePlatEmployeeTypeServiceImpl.java
  10. 7 2
      src/main/java/com/sckj/project/service/impl/service/LargePlatGreenFoodsServiceImpl.java
  11. 6 2
      src/main/java/com/sckj/project/service/impl/service/LargePlatGreenSmartOtherServiceImpl.java
  12. 7 2
      src/main/java/com/sckj/project/service/impl/service/LargePlatGreenSmartSafetyServiceImpl.java
  13. 7 2
      src/main/java/com/sckj/project/service/impl/service/LargePlatGreenSmartServiceImpl.java
  14. 7 2
      src/main/java/com/sckj/project/service/impl/service/LargePlatPostStationServiceImpl.java
  15. 7 2
      src/main/java/com/sckj/project/service/impl/service/LargePlatPropertyListServiceImpl.java
  16. 7 2
      src/main/java/com/sckj/project/service/impl/service/LargePlatPropertyServiceImpl.java
  17. 7 2
      src/main/java/com/sckj/project/service/impl/service/LargePlatPropertyToolsServiceImpl.java
  18. 2 1
      src/main/java/com/sckj/project/service/logistics/ILargePlatLogisticsService.java
  19. 2 3
      src/main/java/com/sckj/project/service/service/ILargePlatAccessService.java
  20. 2 1
      src/main/java/com/sckj/project/service/service/ILargePlatBasicsCompanyService.java
  21. 2 1
      src/main/java/com/sckj/project/service/service/ILargePlatBasicsServerService.java
  22. 2 1
      src/main/java/com/sckj/project/service/service/ILargePlatBasicsService.java
  23. 2 1
      src/main/java/com/sckj/project/service/service/ILargePlatEmployeeHealthService.java
  24. 2 1
      src/main/java/com/sckj/project/service/service/ILargePlatEmployeeTypeService.java
  25. 2 1
      src/main/java/com/sckj/project/service/service/ILargePlatGreenFoodsService.java
  26. 2 1
      src/main/java/com/sckj/project/service/service/ILargePlatGreenSmartOtherService.java
  27. 2 1
      src/main/java/com/sckj/project/service/service/ILargePlatGreenSmartSafetyService.java
  28. 2 1
      src/main/java/com/sckj/project/service/service/ILargePlatGreenSmartService.java
  29. 2 1
      src/main/java/com/sckj/project/service/service/ILargePlatPostStationService.java
  30. 2 1
      src/main/java/com/sckj/project/service/service/ILargePlatPropertyListService.java
  31. 2 1
      src/main/java/com/sckj/project/service/service/ILargePlatPropertyService.java
  32. 2 1
      src/main/java/com/sckj/project/service/service/ILargePlatPropertyToolsService.java
  33. 110 0
      src/main/java/com/sckj/project/task/BuildingTaskService.java
  34. 118 0
      src/main/java/com/sckj/project/task/CarTaskService.java
  35. 112 0
      src/main/java/com/sckj/project/task/EngineeringTaskService.java
  36. 131 0
      src/main/java/com/sckj/project/task/LogisticsTaskService.java
  37. 15 342
      src/main/java/com/sckj/project/task/ProjectTaskController.java
  38. 229 0
      src/main/java/com/sckj/project/task/ServiceTaskService.java
  39. 1 1
      src/main/resources/application-dev.yml

+ 2 - 1
src/main/java/com/sckj/project/service/car/ILargeCarService.java

@@ -1,5 +1,6 @@
 package com.sckj.project.service.car;
 
+import cn.hutool.json.JSONArray;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.sckj.project.domain.car.LargeCar;
 
@@ -13,5 +14,5 @@ import java.util.List;
  */
 public interface ILargeCarService extends IService<LargeCar> {
 
-    void saveOrUpdate(List<LargeCar> list);
+    void saveOrUpdate(JSONArray array);
 }

+ 6 - 2
src/main/java/com/sckj/project/service/impl/car/LargeCarServiceImpl.java

@@ -1,5 +1,6 @@
 package com.sckj.project.service.impl.car;
 
+import cn.hutool.json.JSONArray;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@@ -19,8 +20,12 @@ import java.util.List;
 @Service
 public class LargeCarServiceImpl extends ServiceImpl<LargeCarMapper, LargeCar> implements ILargeCarService {
 
-    public void saveOrUpdate(List<LargeCar> list){
+    public void saveOrUpdate(JSONArray array){
         try {
+            if (array == null){
+                return;
+            }
+            List<LargeCar> list = array.toList(LargeCar.class);
             if (list.size() < 1){
                 return;
             }
@@ -37,7 +42,6 @@ public class LargeCarServiceImpl extends ServiceImpl<LargeCarMapper, LargeCar> i
                 }
             }
         } catch (Exception e) {
-            throw new RuntimeException(e);
         }
     }
 }

+ 6 - 2
src/main/java/com/sckj/project/service/impl/logistics/LargePlatLogisticsServiceImpl.java

@@ -1,6 +1,7 @@
 package com.sckj.project.service.impl.logistics;
 
 
+import cn.hutool.json.JSONArray;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@@ -20,8 +21,12 @@ import java.util.List;
 @Service
 public class LargePlatLogisticsServiceImpl extends ServiceImpl<LargePlatLogisticsMapper, LargeLogistics> implements ILargePlatLogisticsService {
 
-    public void saveOrUpdate(List<LargeLogistics> list){
+    public void saveOrUpdate(JSONArray array){
         try {
+            if (array == null){
+                return;
+            }
+            List<LargeLogistics> list = array.toList(LargeLogistics.class);
             if (list.size() < 1){
                 return;
             }
@@ -38,7 +43,6 @@ public class LargePlatLogisticsServiceImpl extends ServiceImpl<LargePlatLogistic
                 }
             }
         } catch (Exception e) {
-            throw new RuntimeException(e);
         }
     }
 }

+ 6 - 2
src/main/java/com/sckj/project/service/impl/service/LargePlatAccessServiceImpl.java

@@ -1,5 +1,6 @@
 package com.sckj.project.service.impl.service;
 
+import cn.hutool.json.JSONArray;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@@ -19,8 +20,12 @@ import java.util.List;
  */
 @Service
 public class LargePlatAccessServiceImpl extends ServiceImpl<LargePlatAccessMapper, PlatAccess> implements ILargePlatAccessService {
-    public void saveOrUpdate(List<PlatAccess> list){
+    public void saveOrUpdate(JSONArray array){
         try {
+            if (array == null){
+                return;
+            }
+            List<PlatAccess> list = array.toList(PlatAccess.class);
             if (list.size() < 1){
                 return;
             }
@@ -37,7 +42,6 @@ public class LargePlatAccessServiceImpl extends ServiceImpl<LargePlatAccessMappe
                 }
             }
         } catch (Exception e) {
-            throw new RuntimeException(e);
         }
     }
 

+ 7 - 2
src/main/java/com/sckj/project/service/impl/service/LargePlatBasicsCompanyServiceImpl.java

@@ -1,11 +1,13 @@
 package com.sckj.project.service.impl.service;
 
 
+import cn.hutool.json.JSONArray;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.sckj.project.domain.service.PlatBasicsCompany;
 import com.sckj.project.domain.service.PlatBasicsCompany;
+import com.sckj.project.domain.service.PlatBasicsCompany;
 import com.sckj.project.mapper.service.LargePlatBasicsCompanyMapper;
 import com.sckj.project.service.service.ILargePlatBasicsCompanyService;
 import org.springframework.stereotype.Service;
@@ -21,8 +23,12 @@ import java.util.List;
 @Service
 public class LargePlatBasicsCompanyServiceImpl extends ServiceImpl<LargePlatBasicsCompanyMapper, PlatBasicsCompany> implements ILargePlatBasicsCompanyService {
 
-    public void saveOrUpdate(List<PlatBasicsCompany> list){
+    public void saveOrUpdate(JSONArray array){
         try {
+            if (array == null){
+                return;
+            }
+            List<PlatBasicsCompany> list = array.toList(PlatBasicsCompany.class);
             if (list.size() < 1){
                 return;
             }
@@ -39,7 +45,6 @@ public class LargePlatBasicsCompanyServiceImpl extends ServiceImpl<LargePlatBasi
                 }
             }
         } catch (Exception e) {
-            throw new RuntimeException(e);
         }
     }
 }

+ 7 - 2
src/main/java/com/sckj/project/service/impl/service/LargePlatBasicsServerServiceImpl.java

@@ -1,9 +1,11 @@
 package com.sckj.project.service.impl.service;
 
+import cn.hutool.json.JSONArray;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.sckj.project.domain.service.PlatBasicsServer;
+import com.sckj.project.domain.service.PlatBasicsServer;
 import com.sckj.project.mapper.service.LargePlatBasicsServerMapper;
 import com.sckj.project.service.service.ILargePlatBasicsServerService;
 import org.springframework.stereotype.Service;
@@ -19,8 +21,12 @@ import java.util.List;
 @Service
 public class LargePlatBasicsServerServiceImpl extends ServiceImpl<LargePlatBasicsServerMapper, PlatBasicsServer> implements ILargePlatBasicsServerService {
 
-    public void saveOrUpdate(List<PlatBasicsServer> list){
+    public void saveOrUpdate(JSONArray array){
         try {
+            if (array == null){
+                return;
+            }
+            List<PlatBasicsServer> list = array.toList(PlatBasicsServer.class);
             if (list.size() < 1){
                 return;
             }
@@ -37,7 +43,6 @@ public class LargePlatBasicsServerServiceImpl extends ServiceImpl<LargePlatBasic
                 }
             }
         } catch (Exception e) {
-            throw new RuntimeException(e);
         }
     }
 }

+ 7 - 2
src/main/java/com/sckj/project/service/impl/service/LargePlatBasicsServiceImpl.java

@@ -1,9 +1,11 @@
 package com.sckj.project.service.impl.service;
 
+import cn.hutool.json.JSONArray;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.sckj.project.domain.service.PlatBasics;
+import com.sckj.project.domain.service.PlatBasics;
 import com.sckj.project.mapper.service.LargePlatBasicsMapper;
 import com.sckj.project.service.service.ILargePlatBasicsService;
 import org.springframework.stereotype.Service;
@@ -18,8 +20,12 @@ import java.util.List;
  */
 @Service
 public class LargePlatBasicsServiceImpl extends ServiceImpl<LargePlatBasicsMapper, PlatBasics> implements ILargePlatBasicsService {
-    public void saveOrUpdate(List<PlatBasics> list){
+    public void saveOrUpdate(JSONArray array){
         try {
+            if (array == null){
+                return;
+            }
+            List<PlatBasics> list = array.toList(PlatBasics.class);
             if (list.size() < 1){
                 return;
             }
@@ -36,7 +42,6 @@ public class LargePlatBasicsServiceImpl extends ServiceImpl<LargePlatBasicsMappe
                 }
             }
         } catch (Exception e) {
-            throw new RuntimeException(e);
         }
     }
 

+ 7 - 2
src/main/java/com/sckj/project/service/impl/service/LargePlatEmployeeHealthServiceImpl.java

@@ -1,10 +1,12 @@
 package com.sckj.project.service.impl.service;
 
 
+import cn.hutool.json.JSONArray;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.sckj.project.domain.service.PlatEmployeeHealth;
+import com.sckj.project.domain.service.PlatEmployeeHealth;
 import com.sckj.project.mapper.service.LargePlatEmployeeHealthMapper;
 import com.sckj.project.service.service.ILargePlatEmployeeHealthService;
 import org.springframework.stereotype.Service;
@@ -19,8 +21,12 @@ import java.util.List;
  */
 @Service
 public class LargePlatEmployeeHealthServiceImpl extends ServiceImpl<LargePlatEmployeeHealthMapper,  PlatEmployeeHealth> implements ILargePlatEmployeeHealthService {
-    public void saveOrUpdate(List<PlatEmployeeHealth> list){
+    public void saveOrUpdate(JSONArray array){
         try {
+            if (array == null){
+                return;
+            }
+            List<PlatEmployeeHealth> list = array.toList(PlatEmployeeHealth.class);
             if (list.size() < 1){
                 return;
             }
@@ -37,7 +43,6 @@ public class LargePlatEmployeeHealthServiceImpl extends ServiceImpl<LargePlatEmp
                 }
             }
         } catch (Exception e) {
-            throw new RuntimeException(e);
         }
     }
 }

+ 7 - 2
src/main/java/com/sckj/project/service/impl/service/LargePlatEmployeeTypeServiceImpl.java

@@ -1,9 +1,11 @@
 package com.sckj.project.service.impl.service;
 
+import cn.hutool.json.JSONArray;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.sckj.project.domain.service.PlatEmployeeType;
+import com.sckj.project.domain.service.PlatEmployeeType;
 import com.sckj.project.mapper.service.LargePlatEmployeeTypeMapper;
 import com.sckj.project.service.service.ILargePlatEmployeeTypeService;
 import org.springframework.stereotype.Service;
@@ -19,8 +21,12 @@ import java.util.List;
 @Service
 public class LargePlatEmployeeTypeServiceImpl extends ServiceImpl<LargePlatEmployeeTypeMapper, PlatEmployeeType> implements ILargePlatEmployeeTypeService {
 
-    public void saveOrUpdate(List<PlatEmployeeType> list){
+    public void saveOrUpdate(JSONArray array){
         try {
+            if (array == null){
+                return;
+            }
+            List<PlatEmployeeType> list = array.toList(PlatEmployeeType.class);
             if (list.size() < 1){
                 return;
             }
@@ -37,7 +43,6 @@ public class LargePlatEmployeeTypeServiceImpl extends ServiceImpl<LargePlatEmplo
                 }
             }
         } catch (Exception e) {
-            throw new RuntimeException(e);
         }
     }
 }

+ 7 - 2
src/main/java/com/sckj/project/service/impl/service/LargePlatGreenFoodsServiceImpl.java

@@ -1,9 +1,11 @@
 package com.sckj.project.service.impl.service;
 
+import cn.hutool.json.JSONArray;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.sckj.project.domain.service.PlatGreenFoods;
+import com.sckj.project.domain.service.PlatGreenFoods;
 import com.sckj.project.mapper.service.LargePlatGreenFoodsMapper;
 import com.sckj.project.service.service.ILargePlatGreenFoodsService;
 import org.springframework.stereotype.Service;
@@ -19,8 +21,12 @@ import java.util.List;
 @Service
 public class LargePlatGreenFoodsServiceImpl extends ServiceImpl<LargePlatGreenFoodsMapper, PlatGreenFoods> implements ILargePlatGreenFoodsService {
 
-    public void saveOrUpdate(List<PlatGreenFoods> list){
+    public void saveOrUpdate(JSONArray array){
         try {
+            if (array == null){
+                return;
+            }
+            List<PlatGreenFoods> list = array.toList(PlatGreenFoods.class);
             if (list.size() < 1){
                 return;
             }
@@ -37,7 +43,6 @@ public class LargePlatGreenFoodsServiceImpl extends ServiceImpl<LargePlatGreenFo
                 }
             }
         } catch (Exception e) {
-            throw new RuntimeException(e);
         }
     }
 }

+ 6 - 2
src/main/java/com/sckj/project/service/impl/service/LargePlatGreenSmartOtherServiceImpl.java

@@ -1,5 +1,6 @@
 package com.sckj.project.service.impl.service;
 
+import cn.hutool.json.JSONArray;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@@ -19,8 +20,12 @@ import java.util.List;
 @Service
 public class LargePlatGreenSmartOtherServiceImpl extends ServiceImpl<LargePlatGreenSmartOtherMapper, PlatGreenSmartOther> implements ILargePlatGreenSmartOtherService {
 
-    public void saveOrUpdate(List<PlatGreenSmartOther> list){
+    public void saveOrUpdate(JSONArray array){
         try {
+            if (array == null){
+                return;
+            }
+            List<PlatGreenSmartOther> list = array.toList(PlatGreenSmartOther.class);
             if (list.size() < 1){
                 return;
             }
@@ -37,7 +42,6 @@ public class LargePlatGreenSmartOtherServiceImpl extends ServiceImpl<LargePlatGr
                 }
             }
         } catch (Exception e) {
-            throw new RuntimeException(e);
         }
     }
 }

+ 7 - 2
src/main/java/com/sckj/project/service/impl/service/LargePlatGreenSmartSafetyServiceImpl.java

@@ -1,9 +1,11 @@
 package com.sckj.project.service.impl.service;
 
+import cn.hutool.json.JSONArray;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.sckj.project.domain.service.PlatGreenSmartSafety;
+import com.sckj.project.domain.service.PlatGreenSmartSafety;
 import com.sckj.project.mapper.service.LargePlatGreenSmartSafetyMapper;
 import com.sckj.project.service.service.ILargePlatGreenSmartSafetyService;
 import org.springframework.stereotype.Service;
@@ -19,8 +21,12 @@ import java.util.List;
 @Service
 public class LargePlatGreenSmartSafetyServiceImpl extends ServiceImpl<LargePlatGreenSmartSafetyMapper, PlatGreenSmartSafety> implements ILargePlatGreenSmartSafetyService {
 
-    public void saveOrUpdate(List<PlatGreenSmartSafety> list){
+    public void saveOrUpdate(JSONArray array){
         try {
+            if (array == null){
+                return;
+            }
+            List<PlatGreenSmartSafety> list = array.toList(PlatGreenSmartSafety.class);
             if (list.size() < 1){
                 return;
             }
@@ -37,7 +43,6 @@ public class LargePlatGreenSmartSafetyServiceImpl extends ServiceImpl<LargePlatG
                 }
             }
         } catch (Exception e) {
-            throw new RuntimeException(e);
         }
     }
 }

+ 7 - 2
src/main/java/com/sckj/project/service/impl/service/LargePlatGreenSmartServiceImpl.java

@@ -1,9 +1,11 @@
 package com.sckj.project.service.impl.service;
 
+import cn.hutool.json.JSONArray;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.sckj.project.domain.service.PlatGreenSmart;
+import com.sckj.project.domain.service.PlatGreenSmart;
 import com.sckj.project.mapper.service.LargePlatGreenSmartMapper;
 import com.sckj.project.service.service.ILargePlatGreenSmartService;
 import org.springframework.stereotype.Service;
@@ -19,8 +21,12 @@ import java.util.List;
 @Service
 public class LargePlatGreenSmartServiceImpl extends ServiceImpl<LargePlatGreenSmartMapper, PlatGreenSmart> implements ILargePlatGreenSmartService {
 
-    public void saveOrUpdate(List<PlatGreenSmart> list){
+    public void saveOrUpdate(JSONArray array){
         try {
+            if (array == null){
+                return;
+            }
+            List<PlatGreenSmart> list = array.toList(PlatGreenSmart.class);
             if (list.size() < 1){
                 return;
             }
@@ -37,7 +43,6 @@ public class LargePlatGreenSmartServiceImpl extends ServiceImpl<LargePlatGreenSm
                 }
             }
         } catch (Exception e) {
-            throw new RuntimeException(e);
         }
     }
 }

+ 7 - 2
src/main/java/com/sckj/project/service/impl/service/LargePlatPostStationServiceImpl.java

@@ -1,9 +1,11 @@
 package com.sckj.project.service.impl.service;
 
+import cn.hutool.json.JSONArray;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.sckj.project.domain.service.PlatPostStation;
+import com.sckj.project.domain.service.PlatPostStation;
 import com.sckj.project.mapper.service.LargePlatPostStationMapper;
 import com.sckj.project.service.service.ILargePlatPostStationService;
 import org.springframework.stereotype.Service;
@@ -19,8 +21,12 @@ import java.util.List;
 @Service
 public class LargePlatPostStationServiceImpl extends ServiceImpl<LargePlatPostStationMapper, PlatPostStation> implements ILargePlatPostStationService {
 
-    public void saveOrUpdate(List<PlatPostStation> list){
+    public void saveOrUpdate(JSONArray array){
         try {
+            if (array == null){
+                return;
+            }
+            List<PlatPostStation> list = array.toList(PlatPostStation.class);
             if (list.size() < 1){
                 return;
             }
@@ -37,7 +43,6 @@ public class LargePlatPostStationServiceImpl extends ServiceImpl<LargePlatPostSt
                 }
             }
         } catch (Exception e) {
-            throw new RuntimeException(e);
         }
     }
 }

+ 7 - 2
src/main/java/com/sckj/project/service/impl/service/LargePlatPropertyListServiceImpl.java

@@ -1,9 +1,11 @@
 package com.sckj.project.service.impl.service;
 
+import cn.hutool.json.JSONArray;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.sckj.project.domain.service.PlatPropertyList;
+import com.sckj.project.domain.service.PlatPropertyList;
 import com.sckj.project.mapper.service.LargePlatPropertyListMapper;
 import com.sckj.project.service.service.ILargePlatPropertyListService;
 import org.springframework.stereotype.Service;
@@ -19,8 +21,12 @@ import java.util.List;
 @Service
 public class LargePlatPropertyListServiceImpl extends ServiceImpl<LargePlatPropertyListMapper, PlatPropertyList> implements ILargePlatPropertyListService {
 
-    public void saveOrUpdate(List<PlatPropertyList> list){
+    public void saveOrUpdate(JSONArray array){
         try {
+            if (array == null){
+                return;
+            }
+            List<PlatPropertyList> list = array.toList(PlatPropertyList.class);
             if (list.size() < 1){
                 return;
             }
@@ -37,7 +43,6 @@ public class LargePlatPropertyListServiceImpl extends ServiceImpl<LargePlatPrope
                 }
             }
         } catch (Exception e) {
-            throw new RuntimeException(e);
         }
     }
 }

+ 7 - 2
src/main/java/com/sckj/project/service/impl/service/LargePlatPropertyServiceImpl.java

@@ -1,9 +1,11 @@
 package com.sckj.project.service.impl.service;
 
+import cn.hutool.json.JSONArray;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.sckj.project.domain.service.PlatProperty;
+import com.sckj.project.domain.service.PlatProperty;
 import com.sckj.project.mapper.service.LargePlatPropertyMapper;
 import com.sckj.project.service.service.ILargePlatPropertyService;
 import org.springframework.stereotype.Service;
@@ -19,8 +21,12 @@ import java.util.List;
 @Service
 public class LargePlatPropertyServiceImpl extends ServiceImpl<LargePlatPropertyMapper, PlatProperty> implements ILargePlatPropertyService {
 
-    public void saveOrUpdate(List<PlatProperty> list){
+    public void saveOrUpdate(JSONArray array){
         try {
+            if (array == null){
+                return;
+            }
+            List<PlatProperty> list = array.toList(PlatProperty.class);
             if (list.size() < 1){
                 return;
             }
@@ -37,7 +43,6 @@ public class LargePlatPropertyServiceImpl extends ServiceImpl<LargePlatPropertyM
                 }
             }
         } catch (Exception e) {
-            throw new RuntimeException(e);
         }
     }
 }

+ 7 - 2
src/main/java/com/sckj/project/service/impl/service/LargePlatPropertyToolsServiceImpl.java

@@ -1,9 +1,11 @@
 package com.sckj.project.service.impl.service;
 
+import cn.hutool.json.JSONArray;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.sckj.project.domain.service.PlatPropertyTools;
+import com.sckj.project.domain.service.PlatPropertyTools;
 import com.sckj.project.mapper.service.LargePlatPropertyToolsMapper;
 import com.sckj.project.service.service.ILargePlatPropertyToolsService;
 import org.springframework.stereotype.Service;
@@ -19,8 +21,12 @@ import java.util.List;
 @Service
 public class LargePlatPropertyToolsServiceImpl extends ServiceImpl<LargePlatPropertyToolsMapper, PlatPropertyTools> implements ILargePlatPropertyToolsService {
 
-    public void saveOrUpdate(List<PlatPropertyTools> list){
+    public void saveOrUpdate(JSONArray array){
         try {
+            if (array == null){
+                return;
+            }
+            List<PlatPropertyTools> list = array.toList(PlatPropertyTools.class);
             if (list.size() < 1){
                 return;
             }
@@ -37,7 +43,6 @@ public class LargePlatPropertyToolsServiceImpl extends ServiceImpl<LargePlatProp
                 }
             }
         } catch (Exception e) {
-            throw new RuntimeException(e);
         }
     }
 }

+ 2 - 1
src/main/java/com/sckj/project/service/logistics/ILargePlatLogisticsService.java

@@ -1,5 +1,6 @@
 package com.sckj.project.service.logistics;
 
+import cn.hutool.json.JSONArray;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.sckj.project.domain.logistics.LargeLogistics;
 
@@ -13,5 +14,5 @@ import java.util.List;
  */
 public interface ILargePlatLogisticsService extends IService<LargeLogistics> {
 
-    void saveOrUpdate(List<LargeLogistics> list);
+    void saveOrUpdate(JSONArray array);
 }

+ 2 - 3
src/main/java/com/sckj/project/service/service/ILargePlatAccessService.java

@@ -1,11 +1,10 @@
 package com.sckj.project.service.service;
 
 
+import cn.hutool.json.JSONArray;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.sckj.project.domain.service.PlatAccess;
 
-import java.util.List;
-
 /**
  * 便捷出入Service接口
  *
@@ -13,5 +12,5 @@ import java.util.List;
  * @date 2025-03-04
  */
 public interface ILargePlatAccessService extends IService<PlatAccess> {
-    void saveOrUpdate(List<PlatAccess> list);
+    void saveOrUpdate(JSONArray array);
 }

+ 2 - 1
src/main/java/com/sckj/project/service/service/ILargePlatBasicsCompanyService.java

@@ -1,5 +1,6 @@
 package com.sckj.project.service.service;
 
+import cn.hutool.json.JSONArray;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.sckj.project.domain.service.PlatBasicsCompany;
 
@@ -12,5 +13,5 @@ import java.util.List;
  * @date 2025-03-05
  */
 public interface ILargePlatBasicsCompanyService extends IService<PlatBasicsCompany> {
-    void saveOrUpdate(List<PlatBasicsCompany> list);
+    void saveOrUpdate(JSONArray array);
 }

+ 2 - 1
src/main/java/com/sckj/project/service/service/ILargePlatBasicsServerService.java

@@ -1,5 +1,6 @@
 package com.sckj.project.service.service;
 
+import cn.hutool.json.JSONArray;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.sckj.project.domain.service.PlatBasicsServer;
 
@@ -12,5 +13,5 @@ import java.util.List;
  * @date 2025-03-05
  */
 public interface ILargePlatBasicsServerService extends IService<PlatBasicsServer> {
-    void saveOrUpdate(List<PlatBasicsServer> list);
+    void saveOrUpdate(JSONArray array);
 }

+ 2 - 1
src/main/java/com/sckj/project/service/service/ILargePlatBasicsService.java

@@ -1,5 +1,6 @@
 package com.sckj.project.service.service;
 
+import cn.hutool.json.JSONArray;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.sckj.project.domain.service.PlatAccess;
 import com.sckj.project.domain.service.PlatBasics;
@@ -13,5 +14,5 @@ import java.util.List;
  * @date 2025-03-05
  */
 public interface ILargePlatBasicsService extends IService<PlatBasics> {
-    void saveOrUpdate(List<PlatBasics> list);
+    void saveOrUpdate(JSONArray array);
 }

+ 2 - 1
src/main/java/com/sckj/project/service/service/ILargePlatEmployeeHealthService.java

@@ -1,5 +1,6 @@
 package com.sckj.project.service.service;
 
+import cn.hutool.json.JSONArray;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.sckj.project.domain.service.PlatEmployeeHealth;
 
@@ -13,5 +14,5 @@ import java.util.List;
  */
 public interface ILargePlatEmployeeHealthService extends IService<PlatEmployeeHealth> {
 
-    void saveOrUpdate(List<PlatEmployeeHealth> list);
+    void saveOrUpdate(JSONArray array);
 }

+ 2 - 1
src/main/java/com/sckj/project/service/service/ILargePlatEmployeeTypeService.java

@@ -1,5 +1,6 @@
 package com.sckj.project.service.service;
 
+import cn.hutool.json.JSONArray;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.sckj.project.domain.service.PlatEmployeeType;
 
@@ -13,5 +14,5 @@ import java.util.List;
  */
 public interface ILargePlatEmployeeTypeService extends IService<PlatEmployeeType> {
 
-    void saveOrUpdate(List<PlatEmployeeType> list);
+    void saveOrUpdate(JSONArray array);
 }

+ 2 - 1
src/main/java/com/sckj/project/service/service/ILargePlatGreenFoodsService.java

@@ -1,5 +1,6 @@
 package com.sckj.project.service.service;
 
+import cn.hutool.json.JSONArray;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.sckj.project.domain.service.PlatGreenFoods;
 
@@ -13,5 +14,5 @@ import java.util.List;
  */
 public interface ILargePlatGreenFoodsService extends IService<PlatGreenFoods> {
 
-    void saveOrUpdate(List<PlatGreenFoods> list);
+    void saveOrUpdate(JSONArray array);
 }

+ 2 - 1
src/main/java/com/sckj/project/service/service/ILargePlatGreenSmartOtherService.java

@@ -1,5 +1,6 @@
 package com.sckj.project.service.service;
 
+import cn.hutool.json.JSONArray;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.sckj.project.domain.service.PlatGreenSmartOther;
 
@@ -13,5 +14,5 @@ import java.util.List;
  */
 public interface ILargePlatGreenSmartOtherService extends IService<PlatGreenSmartOther> {
 
-    void saveOrUpdate(List<PlatGreenSmartOther> list);
+    void saveOrUpdate(JSONArray array);
 }

+ 2 - 1
src/main/java/com/sckj/project/service/service/ILargePlatGreenSmartSafetyService.java

@@ -1,5 +1,6 @@
 package com.sckj.project.service.service;
 
+import cn.hutool.json.JSONArray;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.sckj.project.domain.service.PlatGreenSmartSafety;
 
@@ -12,6 +13,6 @@ import java.util.List;
  * @date 2025-03-05
  */
 public interface ILargePlatGreenSmartSafetyService extends IService<PlatGreenSmartSafety> {
-    void saveOrUpdate(List<PlatGreenSmartSafety> list);
+    void saveOrUpdate(JSONArray array);
 
 }

+ 2 - 1
src/main/java/com/sckj/project/service/service/ILargePlatGreenSmartService.java

@@ -1,5 +1,6 @@
 package com.sckj.project.service.service;
 
+import cn.hutool.json.JSONArray;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.sckj.project.domain.service.PlatGreenSmart;
 
@@ -13,5 +14,5 @@ import java.util.List;
  */
 public interface ILargePlatGreenSmartService extends IService<PlatGreenSmart> {
 
-    void saveOrUpdate(List<PlatGreenSmart> list);
+    void saveOrUpdate(JSONArray array);
 }

+ 2 - 1
src/main/java/com/sckj/project/service/service/ILargePlatPostStationService.java

@@ -1,5 +1,6 @@
 package com.sckj.project.service.service;
 
+import cn.hutool.json.JSONArray;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.sckj.project.domain.service.PlatPostStation;
 
@@ -13,5 +14,5 @@ import java.util.List;
  */
 public interface ILargePlatPostStationService extends IService<PlatPostStation> {
 
-    void saveOrUpdate(List<PlatPostStation> list);
+    void saveOrUpdate(JSONArray array);
 }

+ 2 - 1
src/main/java/com/sckj/project/service/service/ILargePlatPropertyListService.java

@@ -1,5 +1,6 @@
 package com.sckj.project.service.service;
 
+import cn.hutool.json.JSONArray;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.sckj.project.domain.service.PlatPropertyList;
 
@@ -13,5 +14,5 @@ import java.util.List;
  */
 public interface ILargePlatPropertyListService extends IService<PlatPropertyList> {
 
-    void saveOrUpdate(List<PlatPropertyList> list);
+    void saveOrUpdate(JSONArray array);
 }

+ 2 - 1
src/main/java/com/sckj/project/service/service/ILargePlatPropertyService.java

@@ -1,5 +1,6 @@
 package com.sckj.project.service.service;
 
+import cn.hutool.json.JSONArray;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.sckj.project.domain.service.PlatProperty;
 
@@ -13,5 +14,5 @@ import java.util.List;
  */
 public interface ILargePlatPropertyService extends IService<PlatProperty> {
 
-    void saveOrUpdate(List<PlatProperty> list);
+    void saveOrUpdate(JSONArray array);
 }

+ 2 - 1
src/main/java/com/sckj/project/service/service/ILargePlatPropertyToolsService.java

@@ -1,5 +1,6 @@
 package com.sckj.project.service.service;
 
+import cn.hutool.json.JSONArray;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.sckj.project.domain.service.PlatPropertyTools;
 
@@ -13,5 +14,5 @@ import java.util.List;
  */
 public interface ILargePlatPropertyToolsService extends IService<PlatPropertyTools> {
 
-    void saveOrUpdate(List<PlatPropertyTools> list);
+    void saveOrUpdate(JSONArray array);
 }

+ 110 - 0
src/main/java/com/sckj/project/task/BuildingTaskService.java

@@ -0,0 +1,110 @@
+package com.sckj.project.task;
+
+import cn.hutool.json.JSONArray;
+import cn.hutool.json.JSONUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.sckj.project.config.ApiUrlConfig;
+import com.sckj.project.domain.building.LargeBuilding;
+import com.sckj.project.domain.building.LargeBuildingControl;
+import com.sckj.project.domain.building.LargeBuildingControlAmmeterDetail;
+import com.sckj.project.domain.logistics.LargeHousingLand;
+import com.sckj.project.service.building.ILargePlatBuildingAmmeterDetailService;
+import com.sckj.project.service.building.ILargePlatBuildingControlService;
+import com.sckj.project.service.building.ILargePlatBuildingService;
+import com.sckj.project.util.AESUtil;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpMethod;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Service;
+import org.springframework.web.client.RestClientException;
+import org.springframework.web.client.RestTemplate;
+
+import java.util.List;
+
+@Service
+public class BuildingTaskService {
+
+    @Autowired
+    private ILargePlatBuildingService largePlatBuildingService;
+
+    @Autowired
+    private ILargePlatBuildingControlService largePlatBuildingControlService;
+
+    @Autowired
+    private ILargePlatBuildingAmmeterDetailService largePlatBuildingAmmeterDetailService;
+
+    @Autowired
+    private RestTemplate restTemplate;
+
+    public JSONArray callExternalApi(String url) {
+        try {
+            HttpHeaders headers = new HttpHeaders();
+            headers.set("X-Access-Token", AESUtil.encrypt("M2p5yEL67eZct7gtvT"));
+            HttpEntity<String> entity = new HttpEntity<>(null, headers);
+            ResponseEntity<String> response = restTemplate.exchange(url, HttpMethod.GET, entity, String.class);
+            if (StringUtils.isEmpty(response.getBody())){
+                return null;
+            }
+            return JSONUtil.parseObj(response.getBody()).getJSONArray("data");
+        } catch (RestClientException e) {
+            return null;
+        }
+    }
+
+    public void myTask(){
+
+        /*楼宇表*/
+        try {
+            JSONArray array = callExternalApi(ApiUrlConfig.getBuildingUrl());
+            if (array == null){
+                return;
+            }
+            List<LargeBuilding> list = array.toList(LargeBuilding.class);
+            if (list.size() < 1){
+                return;
+            }
+            largePlatBuildingService.remove(new LambdaQueryWrapper<>());
+            largePlatBuildingService.saveBatch(list);
+        } catch (Exception e) {
+
+        }
+
+        /*楼宇中控*/
+        try {
+            JSONArray array = callExternalApi(ApiUrlConfig.getBuildingControlUrl());
+            if (array == null){
+                return;
+            }
+            List<LargeBuildingControl> list = array.toList(LargeBuildingControl.class);
+            if (list.size() < 1){
+                return;
+            }
+            largePlatBuildingControlService.remove(new LambdaQueryWrapper<>());
+            largePlatBuildingControlService.saveBatch(list);
+        } catch (Exception e) {
+
+        }
+
+        /*楼宇中控电表明细表*/
+        try {
+            JSONArray array = callExternalApi(ApiUrlConfig.getBuildingAmmeterDetailUrl());
+            if (array == null){
+                return;
+            }
+            List<LargeBuildingControlAmmeterDetail> list = array.toList(LargeBuildingControlAmmeterDetail.class);
+            if (list.size() < 1){
+                return;
+            }
+            largePlatBuildingAmmeterDetailService.remove(new LambdaQueryWrapper<>());
+            largePlatBuildingAmmeterDetailService.saveBatch(list);
+        } catch (Exception e) {
+
+        }
+
+
+        System.out.println("楼宇运行同步完成");
+    }
+}

+ 118 - 0
src/main/java/com/sckj/project/task/CarTaskService.java

@@ -0,0 +1,118 @@
+package com.sckj.project.task;
+
+import cn.hutool.json.JSONArray;
+import cn.hutool.json.JSONUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.sckj.project.config.ApiUrlConfig;
+import com.sckj.project.domain.car.LargeCar;
+import com.sckj.project.domain.car.LargeCarDetail;
+import com.sckj.project.domain.car.LargeCarRank;
+import com.sckj.project.domain.car.LargeWarnDetail;
+import com.sckj.project.domain.engineering.LargeCamera;
+import com.sckj.project.service.car.ILargeCarDetailService;
+import com.sckj.project.service.car.ILargeCarRankService;
+import com.sckj.project.service.car.ILargeCarService;
+import com.sckj.project.service.car.ILargeWarnDetailService;
+import com.sckj.project.util.AESUtil;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpMethod;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Service;
+import org.springframework.web.client.RestClientException;
+import org.springframework.web.client.RestTemplate;
+
+import java.util.List;
+
+@Service
+public class CarTaskService {
+
+    @Autowired
+    private ILargeCarService largeCarService;
+
+    @Autowired
+    private ILargeCarDetailService largeCarDetailService;
+
+    @Autowired
+    private ILargeWarnDetailService largeWarnDetailService;
+
+    @Autowired
+    private ILargeCarRankService largeCarRankService;
+
+    @Autowired
+    private RestTemplate restTemplate;
+
+    public JSONArray callExternalApi(String url) {
+        try {
+            HttpHeaders headers = new HttpHeaders();
+            headers.set("X-Access-Token", AESUtil.encrypt("M2p5yEL67eZct7gtvT"));
+            HttpEntity<String> entity = new HttpEntity<>(null, headers);
+            ResponseEntity<String> response = restTemplate.exchange(url, HttpMethod.GET, entity, String.class);
+            if (StringUtils.isEmpty(response.getBody())){
+                return null;
+            }
+            return JSONUtil.parseObj(response.getBody()).getJSONArray("data");
+        } catch (RestClientException e) {
+            return null;
+        }
+    }
+
+    public void myTask(){
+
+        /*公务用车表*/
+        largeCarService.saveOrUpdate(callExternalApi(ApiUrlConfig.getCarUrl()));
+
+        /*公务用车年度增加减少表*/
+        try {
+            JSONArray array = callExternalApi(ApiUrlConfig.getCarChangeUrl());
+            if (array == null){
+                return;
+            }
+            List<LargeCarDetail> list = array.toList(LargeCarDetail.class);
+            if (list.size() < 1){
+                return;
+            }
+            largeCarDetailService.remove(new LambdaQueryWrapper<>());
+            largeCarDetailService.saveBatch(list);
+        } catch (Exception e) {
+
+        }
+
+        /*公务用车预警明细表*/
+        try {
+            JSONArray array = callExternalApi(ApiUrlConfig.getCarWarnUrl());
+            if (array == null){
+                return;
+            }
+            List<LargeWarnDetail> list = array.toList(LargeWarnDetail.class);
+            if (list.size() < 1){
+                return;
+            }
+            largeWarnDetailService.remove(new LambdaQueryWrapper<>());
+            largeWarnDetailService.saveBatch(list);
+        } catch (Exception e) {
+
+        }
+
+        /*公务用车单车活跃排名表*/
+        try {
+            JSONArray array = callExternalApi(ApiUrlConfig.getCarRankUrl());
+            if (array == null){
+                return;
+            }
+            List<LargeCarRank> list = array.toList(LargeCarRank.class);
+            if (list.size() < 1){
+                return;
+            }
+            largeCarRankService.remove(new LambdaQueryWrapper<>());
+            largeCarRankService.saveBatch(list);
+        } catch (Exception e) {
+
+        }
+
+
+        System.out.println("公务用车同步完成");
+    }
+}

+ 112 - 0
src/main/java/com/sckj/project/task/EngineeringTaskService.java

@@ -0,0 +1,112 @@
+package com.sckj.project.task;
+
+import cn.hutool.json.JSONArray;
+import cn.hutool.json.JSONUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.sckj.project.config.ApiUrlConfig;
+import com.sckj.project.domain.building.LargeBuilding;
+import com.sckj.project.domain.engineering.LargeCamera;
+import com.sckj.project.domain.engineering.LargeIssue;
+import com.sckj.project.domain.engineering.LargeProject;
+import com.sckj.project.service.engineering.ILargeCameraService;
+import com.sckj.project.service.engineering.ILargePlatIssueService;
+import com.sckj.project.service.engineering.ILargePlatProjectService;
+import com.sckj.project.util.AESUtil;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpMethod;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Service;
+import org.springframework.web.client.RestClientException;
+import org.springframework.web.client.RestTemplate;
+
+import java.util.List;
+
+@Service
+public class EngineeringTaskService {
+
+    @Autowired
+    private ILargeCameraService largeCameraService;
+
+    @Autowired
+    private ILargePlatIssueService largePlatIssueService;
+
+    @Autowired
+    private ILargePlatProjectService largePlatProjectService;
+
+//    @Autowired
+//    private GenericService<LargeProject> service28;
+
+    @Autowired
+    private RestTemplate restTemplate;
+
+    public JSONArray callExternalApi(String url) {
+        try {
+            HttpHeaders headers = new HttpHeaders();
+            headers.set("X-Access-Token", AESUtil.encrypt("M2p5yEL67eZct7gtvT"));
+            HttpEntity<String> entity = new HttpEntity<>(null, headers);
+            ResponseEntity<String> response = restTemplate.exchange(url, HttpMethod.GET, entity, String.class);
+            if (StringUtils.isEmpty(response.getBody())){
+                return null;
+            }
+            return JSONUtil.parseObj(response.getBody()).getJSONArray("data");
+        } catch (RestClientException e) {
+            return null;
+        }
+    }
+
+    public void myTask(){
+
+        /*监控表*/
+        try {
+            JSONArray array = callExternalApi(ApiUrlConfig.getEngineerCameraUrl());
+            if (array == null){
+                return;
+            }
+            List<LargeCamera> list = array.toList(LargeCamera.class);
+            if (list.size() < 1){
+                return;
+            }
+            largeCameraService.remove(new LambdaQueryWrapper<>());
+            largeCameraService.saveBatch(list);
+        } catch (Exception e) {
+
+        }
+
+        /*上报问题表*/
+        try {
+            JSONArray array = callExternalApi(ApiUrlConfig.getEngineerIssueUrl());
+            if (array == null){
+                return;
+            }
+            List<LargeIssue> list = array.toList(LargeIssue.class);
+            if (list.size() < 1){
+                return;
+            }
+            largePlatIssueService.remove(new LambdaQueryWrapper<>());
+            largePlatIssueService.saveBatch(list);
+        } catch (Exception e) {
+
+        }
+
+        /*项目表*/
+        try {
+            JSONArray array = callExternalApi(ApiUrlConfig.getEngineerProjectUrl());
+            if (array == null){
+                return;
+            }
+            List<LargeProject> list = array.toList(LargeProject.class);
+            if (list.size() < 1){
+                return;
+            }
+            largePlatProjectService.remove(new LambdaQueryWrapper<>());
+            largePlatProjectService.saveBatch(list);
+        } catch (Exception e) {
+
+        }
+
+        System.out.println("工程现场同步完成");
+    }
+}

+ 131 - 0
src/main/java/com/sckj/project/task/LogisticsTaskService.java

@@ -0,0 +1,131 @@
+package com.sckj.project.task;
+
+import cn.hutool.json.JSONArray;
+import cn.hutool.json.JSONUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.sckj.project.config.ApiUrlConfig;
+import com.sckj.project.domain.logistics.*;
+import com.sckj.project.domain.service.PlatBasicsSystem;
+import com.sckj.project.service.logistics.*;
+import com.sckj.project.util.AESUtil;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpMethod;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Service;
+import org.springframework.web.client.RestClientException;
+import org.springframework.web.client.RestTemplate;
+
+import java.util.List;
+
+@Service
+public class LogisticsTaskService {
+
+    @Autowired
+    private ILargePlatHousingLandService largePlatHousingLandService;
+
+    @Autowired
+    private ILargePlatLogisticsService largePlatLogisticsService;
+
+    @Autowired
+    private ILargePlatLogisticsBuildingAssetService largePlatLogisticsBuildingAssetService;
+
+    @Autowired
+    private ILargePlatLogisticsOfficeAssetService largePlatLogisticsOfficeAssetService;
+
+    @Autowired
+    private ILargePlatLogisticsServiceAssetService largePlatLogisticsServiceAssetService;
+
+    @Autowired
+    private RestTemplate restTemplate;
+
+    public JSONArray callExternalApi(String url) {
+        try {
+            HttpHeaders headers = new HttpHeaders();
+            headers.set("X-Access-Token", AESUtil.encrypt("M2p5yEL67eZct7gtvT"));
+            HttpEntity<String> entity = new HttpEntity<>(null, headers);
+            ResponseEntity<String> response = restTemplate.exchange(url, HttpMethod.GET, entity, String.class);
+            if (StringUtils.isEmpty(response.getBody())){
+                return null;
+            }
+            return JSONUtil.parseObj(response.getBody()).getJSONArray("data");
+        } catch (RestClientException e) {
+            return null;
+        }
+    }
+
+    public void myTask(){
+
+        /*房产土地表*/
+        try {
+            JSONArray array = callExternalApi(ApiUrlConfig.getLogisticsHousingUrl());
+            if (array == null){
+                return;
+            }
+            List<LargeHousingLand> list = array.toList(LargeHousingLand.class);
+            if (list.size() < 1){
+                return;
+            }
+            largePlatHousingLandService.remove(new LambdaQueryWrapper<>());
+            largePlatHousingLandService.saveBatch(list);
+        } catch (Exception e) {
+
+        }
+
+        /*后勤运行监控中心表*/
+        largePlatLogisticsService.saveOrUpdate(callExternalApi(ApiUrlConfig.getLogisticsUrl()));
+
+        /*楼宇设备表*/
+        try {
+            JSONArray array = callExternalApi(ApiUrlConfig.getLogisticsBuildingAssetUrl());
+            if (array == null){
+                return;
+            }
+            List<LargeBuildingAssetDirs> list = array.toList(LargeBuildingAssetDirs.class);
+            if (list.size() < 1){
+                return;
+            }
+            largePlatLogisticsBuildingAssetService.remove(new LambdaQueryWrapper<>());
+            largePlatLogisticsBuildingAssetService.saveBatch(list);
+        } catch (Exception e) {
+
+        }
+
+        /*办公资产表*/
+        try {
+            JSONArray array = callExternalApi(ApiUrlConfig.getLogisticsOfficeAssetUrl());
+            if (array == null){
+                return;
+            }
+            List<LargeOfficeAssetDirs> list = array.toList(LargeOfficeAssetDirs.class);
+            if (list.size() < 1){
+                return;
+            }
+            largePlatLogisticsOfficeAssetService.remove(new LambdaQueryWrapper<>());
+            largePlatLogisticsOfficeAssetService.saveBatch(list);
+        } catch (Exception e) {
+
+        }
+
+        /*服务设备表*/
+        try {
+            JSONArray array = callExternalApi(ApiUrlConfig.getLogisticsServiceAssetUrl());
+            if (array == null){
+                return;
+            }
+            List<LargeServiceAssetDirs> list = array.toList(LargeServiceAssetDirs.class);
+            if (list.size() < 1){
+                return;
+            }
+            largePlatLogisticsServiceAssetService.remove(new LambdaQueryWrapper<>());
+            largePlatLogisticsServiceAssetService.saveBatch(list);
+        } catch (Exception e) {
+
+        }
+
+
+        System.out.println("后勤资源同步完成");
+    }
+}

+ 15 - 342
src/main/java/com/sckj/project/task/ProjectTaskController.java

@@ -47,378 +47,51 @@ import java.util.List;
 public class ProjectTaskController {
 
     @Autowired
-    private ILargePlatAccessService largePlatAccessService;
+    private ServiceTaskService serviceTaskService;
 
-    @Autowired
-    private ILargePlatBasicsService largePlatBasicsService;
-
-    @Autowired
-    private ILargePlatBasicsCompanyService largePlatBasicsCompanyService;
-
-    @Autowired
-    private ILargePlatBasicsServerService largePlatBasicsServerService;
-
-    @Autowired
-    private ILargePlatBasicsSystemService largePlatBasicsSystemService;
-
-    @Autowired
-    private ILargePlatEmployeeHealthService largePlatEmployeeHealthService;
-
-    @Autowired
-    private ILargePlatEmployeeHealthIllnessService largePlatEmployeeHealthIllnessService;
-
-    @Autowired
-    private ILargePlatEmployeeTypeService largePlatEmployeeTypeService;
-
-    @Autowired
-    private ILargePlatEmployeeTypeFlowService largePlatEmployeeTypeFlowService;
-
-    @Autowired
-    private ILargePlatGreenFoodsService largePlatGreenFoodsService;
-
-    @Autowired
-    private ILargePlatGreenSmartService largePlatGreenSmartService;
-
-    @Autowired
-    private ILargePlatGreenSmartOtherService largePlatGreenSmartOtherService;
-
-    @Autowired
-    private ILargePlatGreenSmartRankService largePlatGreenSmartRankService;
-
-    @Autowired
-    private ILargePlatGreenSmartSafetyService largePlatGreenSmartSafetyService;
-
-    @Autowired
-    private ILargePlatPostStationService largePlatPostStationService;
-
-    @Autowired
-    private ILargePlatPostStationChartService largePlatPostStationChartService;
-
-    @Autowired
-    private ILargePlatPropertyService largePlatPropertyService;
-
-    @Autowired
-    private ILargePlatPropertyListService largePlatPropertyListService;
-
-    @Autowired
-    private ILargePlatPropertyToolsService largePlatPropertyToolsService;
-
-
-
-    @Autowired
-    private ILargePlatHousingLandService largePlatHousingLandService;
-
-    @Autowired
-    private ILargePlatLogisticsService largePlatLogisticsService;
-
-    @Autowired
-    private ILargePlatLogisticsBuildingAssetService largePlatLogisticsBuildingAssetService;
-
-    @Autowired
-    private ILargePlatLogisticsOfficeAssetService largePlatLogisticsOfficeAssetService;
 
     @Autowired
-    private ILargePlatLogisticsServiceAssetService largePlatLogisticsServiceAssetService;
+    private LogisticsTaskService logisticsTaskService;
 
 
-
-
-    @Autowired
-    private ILargePlatBuildingService largePlatBuildingService;
-
-    @Autowired
-    private ILargePlatBuildingControlService largePlatBuildingControlService;
-
     @Autowired
-    private ILargePlatBuildingAmmeterDetailService largePlatBuildingAmmeterDetailService;
-
-
+    private BuildingTaskService buildingTaskService;
 
 
     @Autowired
-    private ILargeCameraService largeCameraService;
+    private EngineeringTaskService engineeringTaskService;
 
-    @Autowired
-    private ILargePlatIssueService largePlatIssueService;
 
     @Autowired
-    private ILargePlatProjectService largePlatProjectService;
+    private CarTaskService carTaskService;
 
-//    @Autowired
-//    private GenericService<LargeProject> service28;
 
 
 
-
-    @Autowired
-    private ILargeCarService largeCarService;
-
-    @Autowired
-    private ILargeCarDetailService largeCarDetailService;
-
-    @Autowired
-    private ILargeWarnDetailService largeWarnDetailService;
-
-    @Autowired
-    private ILargeCarRankService largeCarRankService;
-
-
-
-    @Autowired
-    private RestTemplate restTemplate;
-
-    public String callExternalApi(String url) {
-        try {
-            System.out.println(url);
-            ResponseEntity<String> response = restTemplate.exchange(url, HttpMethod.GET, null, String.class);
-            return response.getBody();
-        } catch (RestClientException e) {
-            throw new RuntimeException(e);
-        }
-    }
-
-//    @Scheduled(cron = "*/20 * * * * ?")
+    @Scheduled(cron = "0 */2 * * * ?")
     public void taskService() {
-        largePlatAccessService.saveOrUpdate(JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getAccessUrl())).getJSONArray("data").toList(PlatAccess.class));
-        largePlatBasicsService.saveOrUpdate(JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getBasicsApiUrl())).getJSONArray("data").toList(PlatBasics.class));
-        largePlatBasicsCompanyService.saveOrUpdate(JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getBasicsCompanyUrl())).getJSONArray("data").toList(PlatBasicsCompany.class));
-        largePlatBasicsServerService.saveOrUpdate(JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getBasicsServerUrl())).getJSONArray("data").toList(PlatBasicsServer.class));
-        try {
-            List<PlatBasicsSystem> list = JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getBasicsSystemUrl())).getJSONArray("data").toList(PlatBasicsSystem.class);
-            if (list.size() < 1){
-                return;
-            }
-            largePlatBasicsSystemService.remove(new LambdaQueryWrapper<>());
-            largePlatBasicsSystemService.saveBatch(list);
-        } catch (Exception e) {
-            throw new RuntimeException(e);
-        }
-        largePlatEmployeeHealthService.saveOrUpdate(JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getHealthUrl())).getJSONArray("data").toList(PlatEmployeeHealth.class));
-        try {
-            List<PlatEmployeeHealthIllness> list = JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getHealthIllnessUrl())).getJSONArray("data").toList(PlatEmployeeHealthIllness.class);
-            if (list.size() < 1){
-                return;
-            }
-            largePlatEmployeeHealthIllnessService.remove(new LambdaQueryWrapper<>());
-            largePlatEmployeeHealthIllnessService.saveBatch(list);
-        } catch (Exception e) {
-            throw new RuntimeException(e);
-        }
-        largePlatEmployeeTypeService.saveOrUpdate(JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getEmployeeTypeUrl())).getJSONArray("data").toList(PlatEmployeeType.class));
-        try {
-            List<PlatEmployeeTypeFlow> list = JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getEmployeeTypeFlowUrl())).getJSONArray("data").toList(PlatEmployeeTypeFlow.class);
-            if (list.size() < 1){
-                return;
-            }
-            largePlatEmployeeTypeFlowService.remove(new LambdaQueryWrapper<>());
-            largePlatEmployeeTypeFlowService.saveBatch(list);
-        } catch (Exception e) {
-            throw new RuntimeException(e);
-        }
-        largePlatGreenFoodsService.saveOrUpdate(JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getGreenFoodsUrl())).getJSONArray("data").toList(PlatGreenFoods.class));
-        largePlatGreenSmartService.saveOrUpdate(JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getGreenSmartUrl())).getJSONArray("data").toList(PlatGreenSmart.class));
-        largePlatGreenSmartOtherService.saveOrUpdate(JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getGreenSmartOtherUrl())).getJSONArray("data").toList(PlatGreenSmartOther.class));
-        try {
-            List<PlatGreenSmartRank> list = JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getGreenSmartRankUrl())).getJSONArray("data").toList(PlatGreenSmartRank.class);
-            if (list.size() < 1){
-                return;
-            }
-            largePlatGreenSmartRankService.remove(new LambdaQueryWrapper<>());
-            largePlatGreenSmartRankService.saveBatch(list);
-        } catch (Exception e) {
-            throw new RuntimeException(e);
-        }
-        largePlatGreenSmartSafetyService.saveOrUpdate(JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getGreenSmartSafetyUrl())).getJSONArray("data").toList(PlatGreenSmartSafety.class));
-        largePlatPostStationService.saveOrUpdate(JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getPostStationUrl())).getJSONArray("data").toList(PlatPostStation.class));
-        try {
-            List<PlatPostStationChart> list = JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getPostStationChartUrl())).getJSONArray("data").toList(PlatPostStationChart.class);
-            if (list.size() < 1){
-                return;
-            }
-            largePlatPostStationChartService.remove(new LambdaQueryWrapper<>());
-            largePlatPostStationChartService.saveBatch(list);
-        } catch (Exception e) {
-            throw new RuntimeException(e);
-        }
-        largePlatPropertyService.saveOrUpdate(JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getPropertyUrl())).getJSONArray("data").toList(PlatProperty.class));
-        largePlatPropertyListService.saveOrUpdate(JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getPropertyListUrl())).getJSONArray("data").toList(PlatPropertyList.class));
-        largePlatPropertyToolsService.saveOrUpdate(JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getPropertyToolsUrl())).getJSONArray("data").toList(PlatPropertyTools.class));
-
-        System.out.println("服务保障同步完成");
+        serviceTaskService.myTask();
     }
 
 
-//    @Scheduled(cron = "*/20 * * * * ?")
+    @Scheduled(cron = "0 */2 * * * ?")
     public void taskLogistics(){
-        try {
-            List<LargeHousingLand> list = JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getLogisticsHousingUrl())).getJSONArray("data").toList(LargeHousingLand.class);
-            if (list.size() < 1){
-                return;
-            }
-            largePlatHousingLandService.remove(new LambdaQueryWrapper<>());
-            largePlatHousingLandService.saveBatch(list);
-        } catch (Exception e) {
-            throw new RuntimeException(e);
-        }
-
-        largePlatLogisticsService.saveOrUpdate(JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getLogisticsUrl())).getJSONArray("data").toList(LargeLogistics.class));
-
-        try {
-            List<LargeBuildingAssetDirs> list = JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getLogisticsBuildingAssetUrl())).getJSONArray("data").toList(LargeBuildingAssetDirs.class);
-            if (list.size() < 1){
-                return;
-            }
-            largePlatLogisticsBuildingAssetService.remove(new LambdaQueryWrapper<>());
-            largePlatLogisticsBuildingAssetService.saveBatch(list);
-        } catch (Exception e) {
-            throw new RuntimeException(e);
-        }
-
-        try {
-            List<LargeOfficeAssetDirs> list = JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getLogisticsOfficeAssetUrl())).getJSONArray("data").toList(LargeOfficeAssetDirs.class);
-            if (list.size() < 1){
-                return;
-            }
-            largePlatLogisticsOfficeAssetService.remove(new LambdaQueryWrapper<>());
-            largePlatLogisticsOfficeAssetService.saveBatch(list);
-        } catch (Exception e) {
-            throw new RuntimeException(e);
-        }
-
-        try {
-            List<LargeServiceAssetDirs> list = JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getLogisticsServiceAssetUrl())).getJSONArray("data").toList(LargeServiceAssetDirs.class);
-            if (list.size() < 1){
-                return;
-            }
-            largePlatLogisticsServiceAssetService.remove(new LambdaQueryWrapper<>());
-            largePlatLogisticsServiceAssetService.saveBatch(list);
-        } catch (Exception e) {
-            throw new RuntimeException(e);
-        }
-
-
-        System.out.println("后勤资源同步完成");
+        logisticsTaskService.myTask();
     }
 
 
-//    @Scheduled(cron = "*/30 * * * * ?")
+    @Scheduled(cron = "0 */2 * * * ?")
     public void taskBuilding(){
-        try {
-            List<LargeBuilding> list = JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getBuildingUrl())).getJSONArray("data").toList(LargeBuilding.class);
-            if (list.size() < 1){
-                return;
-            }
-            largePlatBuildingService.remove(new LambdaQueryWrapper<>());
-            largePlatBuildingService.saveBatch(list);
-        } catch (Exception e) {
-            throw new RuntimeException(e);
-        }
-
-        try {
-            List<LargeBuildingControl> list = JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getBuildingControlUrl())).getJSONArray("data").toList(LargeBuildingControl.class);
-            if (list.size() < 1){
-                return;
-            }
-            largePlatBuildingControlService.remove(new LambdaQueryWrapper<>());
-            largePlatBuildingControlService.saveBatch(list);
-        } catch (Exception e) {
-            throw new RuntimeException(e);
-        }
-
-        try {
-            List<LargeBuildingControlAmmeterDetail> list = JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getBuildingAmmeterDetailUrl())).getJSONArray("data").toList(LargeBuildingControlAmmeterDetail.class);
-            if (list.size() < 1){
-                return;
-            }
-            largePlatBuildingAmmeterDetailService.remove(new LambdaQueryWrapper<>());
-            largePlatBuildingAmmeterDetailService.saveBatch(list);
-        } catch (Exception e) {
-            throw new RuntimeException(e);
-        }
-
-
-        System.out.println("楼宇运行同步完成");
+        buildingTaskService.myTask();
     }
 
-//    @Scheduled(cron = "*/20 * * * * ?")
+    @Scheduled(cron = "0 */2 * * * ?")
     public void taskEngineering(){
-
-        try {
-            List<LargeCamera> list = JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getEngineerCameraUrl())).getJSONArray("data").toList(LargeCamera.class);
-            if (list.size() < 1){
-                return;
-            }
-            largeCameraService.remove(new LambdaQueryWrapper<>());
-            largeCameraService.saveBatch(list);
-        } catch (Exception e) {
-            throw new RuntimeException(e);
-        }
-
-        try {
-            List<LargeIssue> list = JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getEngineerIssueUrl())).getJSONArray("data").toList(LargeIssue.class);
-            if (list.size() < 1){
-                return;
-            }
-            largePlatIssueService.remove(new LambdaQueryWrapper<>());
-            largePlatIssueService.saveBatch(list);
-        } catch (Exception e) {
-            throw new RuntimeException(e);
-        }
-
-//        JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getEngineerPlanUrl())).getJSONArray("data").toList(LargePlan.class);
-
-        try {
-            List<LargeProject> list = JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getEngineerProjectUrl())).getJSONArray("data").toList(LargeProject.class);
-            if (list.size() < 1){
-                return;
-            }
-            largePlatProjectService.remove(new LambdaQueryWrapper<>());
-            largePlatProjectService.saveBatch(list);
-        } catch (Exception e) {
-            throw new RuntimeException(e);
-        }
-
-        System.out.println("工程现场同步完成");
+        engineeringTaskService.myTask();
     }
 
-//    @Scheduled(cron = "*/25 * * * * ?")
+    @Scheduled(cron = "0 */2 * * * ?")
     public void taskCar(){
-        largeCarService.saveOrUpdate(JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getCarUrl())).getJSONArray("data").toList(LargeCar.class));
-
-        try {
-            List<LargeCarDetail> list = JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getCarChangeUrl())).getJSONArray("data").toList(LargeCarDetail.class);
-            if (list.size() < 1){
-                return;
-            }
-            largeCarDetailService.remove(new LambdaQueryWrapper<>());
-            largeCarDetailService.saveBatch(list);
-        } catch (Exception e) {
-            throw new RuntimeException(e);
-        }
-
-        try {
-            List<LargeWarnDetail> list = JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getCarWarnUrl())).getJSONArray("data").toList(LargeWarnDetail.class);
-            if (list.size() < 1){
-                return;
-            }
-            largeWarnDetailService.remove(new LambdaQueryWrapper<>());
-            largeWarnDetailService.saveBatch(list);
-        } catch (Exception e) {
-            throw new RuntimeException(e);
-        }
-
-        try {
-            List<LargeCarRank> list = JSONUtil.parseObj(callExternalApi(ApiUrlConfig.getCarRankUrl())).getJSONArray("data").toList(LargeCarRank.class);
-            if (list.size() < 1){
-                return;
-            }
-            largeCarRankService.remove(new LambdaQueryWrapper<>());
-            largeCarRankService.saveBatch(list);
-        } catch (Exception e) {
-            throw new RuntimeException(e);
-        }
-
-
-        System.out.println("公务用车同步完成");
+        carTaskService.myTask();
     }
 }

+ 229 - 0
src/main/java/com/sckj/project/task/ServiceTaskService.java

@@ -0,0 +1,229 @@
+package com.sckj.project.task;
+
+import cn.hutool.json.JSONArray;
+import cn.hutool.json.JSONUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.sckj.project.config.ApiUrlConfig;
+import com.sckj.project.domain.service.*;
+import com.sckj.project.service.service.*;
+import com.sckj.project.util.AESUtil;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpMethod;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Service;
+import org.springframework.web.client.RestClientException;
+import org.springframework.web.client.RestTemplate;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@Service
+public class ServiceTaskService {
+
+    @Autowired
+    private ILargePlatAccessService largePlatAccessService;
+
+    @Autowired
+    private ILargePlatBasicsService largePlatBasicsService;
+
+    @Autowired
+    private ILargePlatBasicsCompanyService largePlatBasicsCompanyService;
+
+    @Autowired
+    private ILargePlatBasicsServerService largePlatBasicsServerService;
+
+    @Autowired
+    private ILargePlatBasicsSystemService largePlatBasicsSystemService;
+
+    @Autowired
+    private ILargePlatEmployeeHealthService largePlatEmployeeHealthService;
+
+    @Autowired
+    private ILargePlatEmployeeHealthIllnessService largePlatEmployeeHealthIllnessService;
+
+    @Autowired
+    private ILargePlatEmployeeTypeService largePlatEmployeeTypeService;
+
+    @Autowired
+    private ILargePlatEmployeeTypeFlowService largePlatEmployeeTypeFlowService;
+
+    @Autowired
+    private ILargePlatGreenFoodsService largePlatGreenFoodsService;
+
+    @Autowired
+    private ILargePlatGreenSmartService largePlatGreenSmartService;
+
+    @Autowired
+    private ILargePlatGreenSmartOtherService largePlatGreenSmartOtherService;
+
+    @Autowired
+    private ILargePlatGreenSmartRankService largePlatGreenSmartRankService;
+
+    @Autowired
+    private ILargePlatGreenSmartSafetyService largePlatGreenSmartSafetyService;
+
+    @Autowired
+    private ILargePlatPostStationService largePlatPostStationService;
+
+    @Autowired
+    private ILargePlatPostStationChartService largePlatPostStationChartService;
+
+    @Autowired
+    private ILargePlatPropertyService largePlatPropertyService;
+
+    @Autowired
+    private ILargePlatPropertyListService largePlatPropertyListService;
+
+    @Autowired
+    private ILargePlatPropertyToolsService largePlatPropertyToolsService;
+
+    @Autowired
+    private RestTemplate restTemplate;
+
+
+    public JSONArray callExternalApi(String url) {
+        try {
+            HttpHeaders headers = new HttpHeaders();
+            headers.set("X-Access-Token", AESUtil.encrypt("M2p5yEL67eZct7gtvT"));
+            HttpEntity<String> entity = new HttpEntity<>(null, headers);
+            ResponseEntity<String> response = restTemplate.exchange(url, HttpMethod.GET, entity, String.class);
+            if (StringUtils.isEmpty(response.getBody())){
+                return null;
+            }
+            return JSONUtil.parseObj(response.getBody()).getJSONArray("data");
+        } catch (RestClientException e) {
+            return null;
+        }
+    }
+
+    public void myTask(){
+
+        /*便捷出入*/
+        largePlatAccessService.saveOrUpdate(callExternalApi(ApiUrlConfig.getAccessUrl()));
+
+        /*基础运行数据*/
+        largePlatBasicsService.saveOrUpdate(callExternalApi(ApiUrlConfig.getBasicsApiUrl()));
+
+        /*公司活跃人数*/
+        largePlatBasicsCompanyService.saveOrUpdate(callExternalApi(ApiUrlConfig.getBasicsCompanyUrl()));
+
+        /*服务信息*/
+        largePlatBasicsServerService.saveOrUpdate(callExternalApi(ApiUrlConfig.getBasicsServerUrl()));
+
+        /*系统运行峰值情况分析*/
+        try {
+            JSONArray array = callExternalApi(ApiUrlConfig.getBasicsSystemUrl());
+            if (array == null){
+                return;
+            }
+            List<PlatBasicsSystem> list = array.toList(PlatBasicsSystem.class);
+            if (list.size() < 1){
+                return;
+            }
+            largePlatBasicsSystemService.remove(new LambdaQueryWrapper<>());
+            largePlatBasicsSystemService.saveBatch(list);
+        } catch (Exception e) {
+
+        }
+
+        /*员工健康*/
+        largePlatEmployeeHealthService.saveOrUpdate(callExternalApi(ApiUrlConfig.getHealthUrl()));
+
+        /*多发疾病排行*/
+        try {
+            JSONArray array = callExternalApi(ApiUrlConfig.getHealthIllnessUrl());
+            if (array == null){
+                return;
+            }
+            List<PlatEmployeeHealthIllness> list = array.toList(PlatEmployeeHealthIllness.class);
+            if (list.size() < 1){
+                return;
+            }
+            largePlatEmployeeHealthIllnessService.remove(new LambdaQueryWrapper<>());
+            largePlatEmployeeHealthIllnessService.saveBatch(list);
+        } catch (Exception e) {
+
+        }
+
+        /*员工概况*/
+        largePlatEmployeeTypeService.saveOrUpdate(callExternalApi(ApiUrlConfig.getEmployeeTypeUrl()));
+
+        /*近一周人流量统计*/
+        try {
+            JSONArray array = callExternalApi(ApiUrlConfig.getEmployeeTypeFlowUrl());
+            if (array == null){
+                return;
+            }
+            List<PlatEmployeeTypeFlow> list = array.toList(PlatEmployeeTypeFlow.class);
+            if (list.size() < 1){
+                return;
+            }
+            largePlatEmployeeTypeFlowService.remove(new LambdaQueryWrapper<>());
+            largePlatEmployeeTypeFlowService.saveBatch(list);
+        } catch (Exception e) {
+
+        }
+
+        /*菜谱数据*/
+        largePlatGreenFoodsService.saveOrUpdate(callExternalApi(ApiUrlConfig.getGreenFoodsUrl()));
+
+        /*绿智食堂*/
+        largePlatGreenSmartService.saveOrUpdate(callExternalApi(ApiUrlConfig.getGreenSmartUrl()));
+
+        /*绿智食堂 其他参数*/
+        largePlatGreenSmartOtherService.saveOrUpdate(callExternalApi(ApiUrlConfig.getGreenSmartOtherUrl()));
+
+        /*绿智食堂 排名*/
+        try {
+            JSONArray array = callExternalApi(ApiUrlConfig.getGreenSmartRankUrl());
+            if (array == null){
+                return;
+            }
+            List<PlatGreenSmartRank> list = array.toList(PlatGreenSmartRank.class);
+            if (list.size() < 1){
+                return;
+            }
+            largePlatGreenSmartRankService.remove(new LambdaQueryWrapper<>());
+            largePlatGreenSmartRankService.saveBatch(list);
+        } catch (Exception e) {
+
+        }
+
+        /*食堂安全管理*/
+        largePlatGreenSmartSafetyService.saveOrUpdate(callExternalApi(ApiUrlConfig.getGreenSmartSafetyUrl()));
+
+        /*物业服务*/
+        largePlatPostStationService.saveOrUpdate(callExternalApi(ApiUrlConfig.getPostStationUrl()));
+
+        /*近六个月报修分类占比*/
+        try {
+            JSONArray array = callExternalApi(ApiUrlConfig.getPostStationChartUrl());
+            if (array == null){
+                return;
+            }
+            List<PlatPostStationChart> list = array.toList(PlatPostStationChart.class);
+            if (list.size() < 1){
+                return;
+            }
+            largePlatPostStationChartService.remove(new LambdaQueryWrapper<>());
+            largePlatPostStationChartService.saveBatch(list);
+        } catch (Exception e) {
+
+        }
+
+        /*共享驿站*/
+        largePlatPropertyService.saveOrUpdate(callExternalApi(ApiUrlConfig.getPropertyUrl()));
+
+        /*驿站列表*/
+        largePlatPropertyListService.saveOrUpdate(callExternalApi(ApiUrlConfig.getPropertyListUrl()));
+
+        /*工具表列表*/
+        largePlatPropertyToolsService.saveOrUpdate(callExternalApi(ApiUrlConfig.getPropertyToolsUrl()));
+
+        System.out.println("服务保障同步完成");
+    }
+}

+ 1 - 1
src/main/resources/application-dev.yml

@@ -35,7 +35,7 @@ logging:
 # 接口地址配置
 apiurl:
   # 接口前缀
-  prefixUrl: http://192.168.110.247:8115/large/synchronize
+  prefixUrl: http://192.168.110.247:8115/synchronize
 
   # 服务保障中心
   accessUrl: /getServiceAccess