add

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

@@ -130,6 +130,7 @@ public class GLPPGFWebsitWorkerServiceImpl implements GLPPGFWebsitWorkerService
             uprecs.entrySet().stream()
                     .forEach(entry -> wxgs.add(entry.getValue()));
             itfTblWangdianWxgDownloadService.updateBatchById(wxgs);
+            wxgs.clear();
         }
 
     }

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

@@ -132,13 +132,7 @@ public class GLPPWXGQueryAddServiceImpl implements GLPPWXGQueryAddService {
 
         // 提取格力现有的网点师傅数据信息
         wxgDownladRecs =  itfTblWangdianWxgDownloadService.lambdaQuery()
-                .select(ItfTblWangdianWxgDownload::getWxgid,
-                        ItfTblWangdianWxgDownload::getWxgno,
-                        ItfTblWangdianWxgDownload::getWdno,
-                        ItfTblWangdianWxgDownload::getSfzen,
-                        ItfTblWangdianWxgDownload::getWxgmc,
-                        ItfTblWangdianWxgDownload::getYddh,
-                        ItfTblWangdianWxgDownload::getFlag)
+                .eq(ItfTblWangdianWxgDownload::getGreeStatus,0)
                 // .eq(ItfTblWangdianWxgDownload::getSfzen,"421022197809157619")// 测试用
                 .like(ItfTblWangdianWxgDownload::getWdno,"S%").list();
 
@@ -164,9 +158,11 @@ public class GLPPWXGQueryAddServiceImpl implements GLPPWXGQueryAddService {
                 GreeResponseHelper response = greeLogic.greePost(wdqyapi, JSONObject.toJSONString(req), publicService.getCompanyId(wxg.getWdno()));
                 // 失败不处理
                 if (response.getStatus() == 200){
+                    wxg.setGreeStatus(1);
                     WxgQueryInfo resultDatax = JSONObject.parseObject(response.getData().toString(), WxgQueryInfo.class);
                     // 无证件不处理
                     if ( resultDatax.getWangdianWxgVos().size()<1){
+                        wxg.updateById();
                         continue;
                     }
                     wvos = resultDatax.getWangdianWxgVos().get(0);
@@ -188,10 +184,9 @@ public class GLPPWXGQueryAddServiceImpl implements GLPPWXGQueryAddService {
                         workerCertGreeService.saveOrUpdateBatch(wcgs);
                         wcgs.clear();
                     }
-
+                    wxg.updateById();
                 } else {
-                    log.info("接口同步获取总部网点师傅证件信息失败-师傅证件信息:{}", wxg.getSfzen());
-                    log.info("msg:{}", response.getMsg());
+                    log.info("接口同步获取总部网点师傅证件信息失败-师傅证件信息:{} - {}", wxg.getSfzen(),response.getMsg());
                 }
             } catch (Exception ex) {
                 ex.printStackTrace();
@@ -385,9 +380,11 @@ public class GLPPWXGQueryAddServiceImpl implements GLPPWXGQueryAddService {
                 // log.info("总部获取的工程师证件照信息 response :{}", JSONObject.toJSONString(response));
                 // 失败不处理
                 if (response.getStatus() == 200){
+                    wxg.setCertStatus(1);
                     WxgQueryInfo resultDatax = JSONObject.parseObject(response.getData().toString(), WxgQueryInfo.class);
                     // 无证件不处理
                     if ( resultDatax.getWangdianWxgVos().size()<1){
+                        wxg.updateById();
                         continue;
                     }
 
@@ -403,7 +400,6 @@ public class GLPPWXGQueryAddServiceImpl implements GLPPWXGQueryAddService {
                     addDataCert(addList);
                     // 修改保险信息
                     upWebsitWorker(upWebsitWorkers);
-                    wxg.setCertStatus(1);
                     wxg.updateById();
                     // log.info("工程师证件照信息同步成功-师傅证件信息:{}", wxg.getSfzen());
                 } else {

src/main/resources/bootstrap-prd.properties

@@ -209,7 +209,7 @@ fsxwxg=600000
 fsswxg=600000
 gzxwxg=600000
 gzswxg=600000
-gfwww=600000
+gfwww=60000
 #类别大类、小类、系列、机型
 lbdl=600000
 lbxl=600000