add

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

@@ -1,6 +1,7 @@
 package com.zfire.jiasm.syncdata.download.worker;
 
 
+import com.baomidou.mybatisplus.core.toolkit.IdWorker;
 import com.zfire.jiasm.syncdata.constant.TaskConfigEnum;
 import com.zfire.jiasm.syncdata.service.GLPPWXGQueryAddService;
 import lombok.extern.slf4j.Slf4j;
@@ -9,6 +10,8 @@ import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
+import java.io.File;
+import java.io.IOException;
 import java.text.SimpleDateFormat;
 import java.util.Date;
 
@@ -58,6 +61,13 @@ public class GLPPWXGQueryAdd {
             return;
         }
 
+       // 创建目录
+        SimpleDateFormat sdfs = new SimpleDateFormat("yyyyMM/");
+        File file =new File(sdfs.format(new Date()));
+        if  (!file .exists()  && !file .isDirectory()){
+            file .mkdir();
+        }
+
         SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
 
         log.info("开始生成网点师傅证件照信息: \uF0B7{}",sdf.format(new Date()));

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

@@ -213,6 +213,7 @@ public class GLPPWXGQueryAddServiceImpl implements GLPPWXGQueryAddService {
 
         for (WorkerCert item :workerCertList){
             try{
+                // 生成图片
                 processCertInfo(item);
                 workerCertUpList.add(item);
 
@@ -222,7 +223,6 @@ public class GLPPWXGQueryAddServiceImpl implements GLPPWXGQueryAddService {
                 updateWorkerCertInfo(workerCertUpList, 0);
                 log.info("生成师傅证件照信息失败worker_cert.id= {}",item.getId());
             }
-
         }
 
         updateWorkerCertInfo(workerCertUpList, 0);
@@ -230,7 +230,7 @@ public class GLPPWXGQueryAddServiceImpl implements GLPPWXGQueryAddService {
 
     private void updateWorkerCertInfo(List<WorkerCert> workerCertUpList, int i) {
         if (workerCertUpList.size() > i) {
-            workerCertService.saveOrUpdateBatch(workerCertUpList);
+            workerCertService.updateBatchById(workerCertUpList);
             workerCertUpList.clear();
         }
     }