add

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

@@ -18,6 +18,7 @@ import com.zfire.jiasm.syncdata.response.WangdianWxgVos;
 import com.zfire.jiasm.syncdata.response.WxgQueryInfo;
 import com.zfire.jiasm.syncdata.service.GLPPWXGQueryAddService;
 import com.zfire.jiasm.syncdata.service.PublicService;
+import com.zfire.jiasm.syncdata.test;
 import com.zfire.jiasm.syncdata.utils.MyBeanUtils;
 import com.zfire.jiasm.syncdata.utils.oss.OSSUtil;
 import lombok.extern.slf4j.Slf4j;
@@ -800,6 +801,7 @@ public class GLPPWXGQueryAddServiceImpl implements GLPPWXGQueryAddService {
                              List<String> workerIdandNames) throws Exception {
         // 同步-新增证件信息
         for (ZJInfo zj: wvos.getZjInfoList()){
+            Boolean addFlag = Boolean.FALSE;
             // 保险证单独处理 只有修改无需新增操作
             // websit.category_type决定保险类型 自建+不为商用(家用)其他商用
             // 家用 insure_worker_record
@@ -807,10 +809,6 @@ public class GLPPWXGQueryAddServiceImpl implements GLPPWXGQueryAddService {
             // websit_worker
 
 
-
-
-
-
             // workerid+证件名称锁定不重复
             if (workerIdandNames.contains(workerId+zj.getZjmc().trim())){
                 continue;
@@ -818,6 +816,15 @@ public class GLPPWXGQueryAddServiceImpl implements GLPPWXGQueryAddService {
 
             // 历史数据存在不新增
             if (WorkerCertWorkerIdMaps.containsKey(workerId)){
+                for (WorkerCert item:WorkerCertWorkerIdMaps.get(workerId)){
+                    // 名称相同 即表中已存在，不新增
+                    if (item.getCertName().equals(zj.getZjmc().trim())){
+                        addFlag = Boolean.TRUE;
+                        break;
+                    }
+                }
+            }
+            if (addFlag){
                 continue;
             }