人员库入gbase

src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java

@@ -111,7 +111,7 @@ public class ApplicationEvent {
 //            pointService.personPullAndSave(start, end);
 //            gBaseJJDService.pullAndSave(start, end);
 //            riskPersonalService.fixed();
-            personalService.syncPerson();
+//            personalService.syncPerson();
 //
 //            petitionService.petitionModelTask(initDomain(List.of(40)));
 //            riskTaskService.eduModelTask(initDomain(List.of(34)));
@@ -144,7 +144,7 @@ public class ApplicationEvent {
 //            pointService.syncFatherEducation(initDomain(List.of(112)));
 //            pointService.syncMotherEducation(initDomain(List.of(113)));
 //            pointService.syncDomicileType(initDomain(List.of(114)));
-            pointService.syncCriminalPunishment(initDomain(List.of(115)));// 需重跑 报错
+//            pointService.syncCriminalPunishment(initDomain(List.of(115)));// 需重跑 报错
 //            pointService.syncAdministrativePunishment(initDomain(List.of(116)));// 需重跑
 //            pointService.syncParentsDivorce(initDomain(List.of(117)));
 //            pointService.syncFamilyDie(initDomain(List.of(118)));
@@ -161,8 +161,8 @@ public class ApplicationEvent {
 //            pointService.syncSeriousIllness(initDomain(List.of(126)));
 //            pointService.syncFamilySeriousIllness(initDomain(List.of(127)));
 //            pointService.syncPetitionDissatisfied(initDomain(List.of(128)));
-            pointService.syncIsSpecialPeople(initDomain(List.of(129)));
-            pointService.syncSpecialPeopleType(initDomain(List.of(130)));
+//            pointService.syncIsSpecialPeople(initDomain(List.of(129)));
+//            pointService.syncSpecialPeopleType(initDomain(List.of(130)));
             // *********暂时不要**********
 //            riskTaskService.caseModelTask(initDomain(List.of(35)));
 //            riskTaskService.heightFight(initDomain(List.of(42)));

src/main/java/com/biutag/supervisiondata/service/impl/PersonalServiceImpl.java

@@ -496,7 +496,7 @@ public class PersonalServiceImpl implements PersonalService {
     public void syncPerson() {
         wdpcPersonRepository.getBaseMapper().truncateTable();
         List<RiskPersonal> personals = personalRepository.list(new LambdaQueryWrapper<RiskPersonal>()
-                .select(RiskPersonal::getIdCode, RiskPersonal::getIdCode)
+                .select(RiskPersonal::getIdCode, RiskPersonal::getId)
                 .eq(RiskPersonal::getDel, 0));
 
         List<WdpcPerson> personList = new ArrayList<>();

src/main/resources/application.yml

@@ -57,7 +57,7 @@ spring:
     wdpc:
       type: com.zaxxer.hikari.HikariDataSource
       driver-class-name: com.gbase.jdbc.Driver
-      jdbc-url: jdbc:gbase://65.47.16.209:5258/csga_wdpcdb
+      jdbc-url: jdbc:gbase://65.47.16.209:5258/csga_wdpcdb?rewriteBatchedStatements=true
       username: csga_wdpc
       password: csga_wdpc@123
       hikari: