yaozhixue 1 năm trước cách đây
mục cha
commit
cb48b5786f

+ 21 - 4
src/main/java/com/zfire/jiasm/syncdata/download/basedata/GLPPGFWebsitWorker.java

@@ -117,13 +117,30 @@ public class GLPPGFWebsitWorker {
         if (gfwwwc.equals(TaskConfigEnum.FALSE.getCode())){
             return;
         }
+        try {
+            log.info("开始处理网点维修工基础资料生成师傅数据: \uF0B7{}",sdf.format(new Date()));
+            glppgfWebsitWorkerService.inputWorkerData();
+            log.info("处理网点维修工基础资料生成师傅数据结束: \uF0B7{}",sdf.format(new Date()));
+        } catch (Exception ex) {
+            log.info("网点维修工基础资料生成师傅数据失败");
+            ex.printStackTrace();
+        }
+    }
+
 
+
+    @Scheduled(fixedDelayString = "${gfwww}")
+    private void processWebsitWorkerData() {
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        if (gfwwwc.equals(TaskConfigEnum.FALSE.getCode())){
+            return;
+        }
         try {
-            log.info("开始处理网点维修工基础资料落本地表: \uF0B7{}",sdf.format(new Date()));
-            glppgfWebsitWorkerService.inputData();
-            log.info("处理网点维修工基础资料落本地表结束: \uF0B7{}",sdf.format(new Date()));
+            log.info("开始处理网点维修工基础资料生成网点师傅数据: \uF0B7{}",sdf.format(new Date()));
+            glppgfWebsitWorkerService.inputWebsitWorkerData();
+            log.info("处理网点维修工基础资料生成网点师傅数据结束: \uF0B7{}",sdf.format(new Date()));
         } catch (Exception ex) {
-            log.info("网点维修工基础资料落本地表失败");
+            log.info("网点维修工基础资料生成网点师傅数据失败");
             ex.printStackTrace();
         }
     }

+ 2 - 1
src/main/java/com/zfire/jiasm/syncdata/service/GLPPGFWebsitWorkerService.java

@@ -16,5 +16,6 @@ public interface GLPPGFWebsitWorkerService {
 
     void extractedTMYP(JSONArray jsonArray);
 
-    void inputData();
+    void inputWorkerData();
+    void inputWebsitWorkerData();
 }

+ 7 - 7
src/main/java/com/zfire/jiasm/syncdata/service/impl/GLPPGFWebsitWorkerServiceImpl.java

@@ -87,15 +87,15 @@ public class GLPPGFWebsitWorkerServiceImpl implements GLPPGFWebsitWorkerService
 
 
     @Override
-    public void inputData(){
+    public void inputWorkerData(){
         // 新增师傅数据 只新增不修改
         inputDataWorker();
-        log.info("生成师傅数据结果");
+    }
 
+    @Override
+    public void inputWebsitWorkerData(){
         // 添加网点师傅数据及平台与商户网点师傅数据  worker_brand_account(师傅网点对应品牌网点信息表) + websit_worker(网点师傅信息表))
         inputDataWebsitWorker();
-        log.info("添加网点师傅数据结果");
-
     }
 
     void inputDataWebsitWorker(){
@@ -356,21 +356,21 @@ public class GLPPGFWebsitWorkerServiceImpl implements GLPPGFWebsitWorkerService
             }
 
             // 修改品牌商网点师傅数据
-            if (upWorkerBrandAccounts.size()>1000){
+            if (upWorkerBrandAccounts.size()>100){
                 workerBrandAccountService.updateBatchById(upWorkerBrandAccounts);
                 log.info("修改了品牌商网点师傅数据:{}",upWorkerBrandAccounts.size());
                 upWorkerBrandAccounts.clear();
             }
 
             // 新增品牌师傅网点信息
-            if (addwbas.size()>1000){
+            if (addwbas.size()>100){
                 workerBrandAccountService.saveBatch(addwbas);
                 log.info("新增了品牌商网点师傅数据:{}",upWorkerBrandAccounts.size());
                 addwbas.clear();
             }
 
             // 新增师傅所在平台网点信息
-            if (websitWorkeradd.size()>1000){
+            if (websitWorkeradd.size()>100){
                 websitWorkerService.saveBatch(websitWorkeradd);
                 log.info("新增了师傅所在平台网点信息:{}",upWorkerBrandAccounts.size());
                 websitWorkeradd.clear();