add

src/main/java/com/zfire/jiasm/syncdata/download/worker/GLPPWXGQueryAdd.java

@@ -51,10 +51,20 @@ public class GLPPWXGQueryAdd {
         wxgQueryAddWXGInfo();
     }
 
+    // 从格力总部同步师傅的证件照数据生成平台的证件图信息
     @Scheduled(fixedDelayString = "${zjzxx}")
     public void processCert() throws Exception {
-        // 格力总部同步下来的证件照处理
-        // wxgQueryAddCert();
+       if (zjzxxc.equals(TaskConfigEnum.FALSE.getCode())){
+            return;
+        }
+
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+
+        log.info("开始生成网点师傅证件照信息: \uF0B7{}",sdf.format(new Date()));
+
+        glppwxgQueryAddService.extractedCert();
+
+        log.info("生成网点师傅证件照信息结束: \uF0B7{}",sdf.format(new Date()));
     }
 
 
@@ -98,28 +108,6 @@ public class GLPPWXGQueryAdd {
     }
 
     /**
-     * 从格力总部同步师傅的证件照数据生成平台的证件图信息
-     */
-    public void wxgQueryAddCert() throws Exception {
-        if (zjzxxc.equals(TaskConfigEnum.FALSE.getCode())){
-            return;
-        }
-
-        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-
-        log.info("开始生成网点师傅证件照信息: \uF0B7{}",sdf.format(new Date()));
-        try {
-            glppwxgQueryAddService.extractedCert();
-            log.info("同步生成网点师傅证件照信息结束: \uF0B7{}",sdf.format(new Date()));
-        } catch (Exception ex) {
-            ex.printStackTrace();
-            log.info("同步生成网点师傅证件照信息失败: \uF0B7{}",sdf.format(new Date()));
-        }
-
-    }
-
-
-    /**
      * 新增 师傅服务类目信息 这里只做新增(只新增从格力总部过来的师傅服务的类目信息)
      */
     public void wxgQueryAddCategory() throws Exception {

src/main/java/com/zfire/jiasm/syncdata/service/impl/GLPPWXGQueryAddServiceImpl.java

@@ -207,16 +207,32 @@ public class GLPPWXGQueryAddServiceImpl implements GLPPWXGQueryAddService {
 
         workerCertList = workerCertService.lambdaQuery()
                 .eq(WorkerCert::getOutZjljProcess,0)
+                .eq(WorkerCert::getWorkerId,"1694325998410199043")// 测试用
                 .isNotNull(WorkerCert::getOutZjlj).list();
         extractedCertInfo();
 
         for (WorkerCert item :workerCertList){
-            processCertInfo(item);
+            try{
+                processCertInfo(item);
+                workerCertUpList.add(item);
 
-        }
+                updateWorkerCertInfo(workerCertUpList, 100);
+            } catch (Exception ex) {
+                ex.printStackTrace();
+                updateWorkerCertInfo(workerCertUpList, 0);
+                log.info("生成师傅证件照信息失败worker_cert.id= {}",item.getId());
+            }
 
+        }
 
+        updateWorkerCertInfo(workerCertUpList, 0);
+    }
 
+    private void updateWorkerCertInfo(List<WorkerCert> workerCertUpList, int i) {
+        if (workerCertUpList.size() > i) {
+            workerCertService.saveOrUpdateBatch(workerCertUpList);
+            workerCertUpList.clear();
+        }
     }
 
     private void upWebsitWorker(List<WebsitWorker> websitWorkerUp) {
@@ -772,6 +788,7 @@ public class GLPPWXGQueryAddServiceImpl implements GLPPWXGQueryAddService {
             if (StringUtils.isNotEmpty(id2)){
                 workerCert.setFileUrl2(id2);
                 workerCert.setOutFileUrl2(result.get(1));
+                workerCert.setOutZjljProcess(1);
                 new File(id2).delete();
             }
         } else {
@@ -779,6 +796,7 @@ public class GLPPWXGQueryAddServiceImpl implements GLPPWXGQueryAddService {
             if (StringUtils.isNotEmpty(id)){
                 workerCert.setFileUrl(id);
                 workerCert.setOutFileUrl(workerCert.getOutZjlj());
+                workerCert.setOutZjljProcess(1);
                 new File(id).delete();
             }
         }