yaozhixue 1 år sedan
förälder
incheckning
7086d28793

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

@@ -450,6 +450,7 @@ public class GLPPWXGQueryAddServiceImpl implements GLPPWXGQueryAddService {
 
         workerCertList = workerCertService.lambdaQuery()
                 .eq(WorkerCert::getOutZjljProcess,0)
+                .lt(WorkerCert::getOutZjljProcessTimes,10)
                 //.in(WorkerCert::getWorkerId,workerIds)
                 // .eq(WorkerCert::getWorkerId,"S18229336122")// 测试用
                 .isNotNull(WorkerCert::getOutZjlj)
@@ -1187,6 +1188,7 @@ public class GLPPWXGQueryAddServiceImpl implements GLPPWXGQueryAddService {
                     new File(id).delete();
                 } else {
                     flag = Boolean.FALSE;
+                    workerCert.setOutZjljProcessTimes(workerCert.getOutZjljProcessTimes() + 1);
                     workerCert.setOutSyncErrorMsg("生成师傅证件照信息失败:" + result.get(0));
                 }
             }
@@ -1200,6 +1202,7 @@ public class GLPPWXGQueryAddServiceImpl implements GLPPWXGQueryAddService {
                         new File(id2).delete();
                     } else {
                         flag = Boolean.FALSE;
+                        workerCert.setOutZjljProcessTimes(workerCert.getOutZjljProcessTimes() + 1);
                         workerCert.setOutSyncErrorMsg("生成师傅证件照信息失败:" + result.get(1));
                     }
                 } else {
@@ -1211,6 +1214,7 @@ public class GLPPWXGQueryAddServiceImpl implements GLPPWXGQueryAddService {
                             new File(id2).delete();
                         } else {
                             flag = Boolean.FALSE;
+                            workerCert.setOutZjljProcessTimes(workerCert.getOutZjljProcessTimes() + 1);
                             workerCert.setOutSyncErrorMsg("生成师傅证件照信息失败:" + result.get(i));
                             break;
                         }
@@ -1223,6 +1227,7 @@ public class GLPPWXGQueryAddServiceImpl implements GLPPWXGQueryAddService {
             }
 
             if (flag){
+                workerCert.setOutZjljProcessTimes(0);
                 workerCert.setOutZjljProcess(1);
             }
             workerCert.setOutSyncTime(new Date());
@@ -1232,10 +1237,12 @@ public class GLPPWXGQueryAddServiceImpl implements GLPPWXGQueryAddService {
                 if (StringUtils.isNotEmpty(id)){
                     workerCert.setFileUrl(id);
                     workerCert.setOutFileUrl(workerCert.getOutZjlj());
+                    workerCert.setOutZjljProcessTimes(0);
                     workerCert.setOutZjljProcess(1);
                     workerCert.setOutSyncTime(new Date());
                     new File(id).delete();
                 } else {
+                    workerCert.setOutZjljProcessTimes(workerCert.getOutZjljProcessTimes() + 1);
                     workerCert.setOutSyncErrorMsg("生成师傅证件照信息失败:" + workerCert.getOutZjlj());
                 }
             }