diff --git a/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java b/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java index f208471..85b33eb 100644 --- a/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java +++ b/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java @@ -104,65 +104,61 @@ public class ApplicationEvent { CompletableFutureUtil.runSync(() -> { // 测试数据 // gBaseJJDService.pullDataAndSaveRedis(start, end); - - -// personalService.init(); -// personalService.pullInvestigate(); -// personalService.pullPsychosis(); -// gBaseJJDService.pullAndSave(start, end); -// gBaseSHRWFRService.pullAndSave(start, end); -// petitionService.personPullAndSave(start, end); -// personalService.pullPetitionAgain(); -// pointService.personPullAndSave(start, end); + personalService.init(); + personalService.pullInvestigate(); + personalService.pullPsychosis(); + gBaseJJDService.pullAndSave(start, end); + gBaseSHRWFRService.pullAndSave(start, end); + petitionService.personPullAndSave(start, end); + personalService.pullPetitionAgain(); + pointService.personPullAndSave(start, end); riskPersonalService.fixed(); -// -// -// -// petitionService.petitionModelTask(initDomain(List.of(40))); -// riskTaskService.eduModelTask(initDomain(List.of(34))); -// riskTaskService.infoModelTask(initDomain(List.of(32,33))); + + petitionService.petitionModelTask(initDomain(List.of(40))); + riskTaskService.eduModelTask(initDomain(List.of(34))); + riskTaskService.infoModelTask(initDomain(List.of(32,33))); // marriageService.marriageModelTask(initDomain(List.of(39,51))); -// pointService.syncSecurity(initDomain(List.of(37))); -// habitService.habitModelTask(start, initDomain(List.of(36,60,61,62))); -// -// pointService.syncCarUser(initDomain(List.of(53))); -// riskTaskService.riskAreaModelTask(initDomain(List.of(41))); -// pointService.syncScore(initDomain(List.of(43))); -// pointService.syncViolence(initDomain(List.of(44))); -// noControlService.syncNoControlData(initDomain(List.of(45))); -// pointService.syncDrug(initDomain(List.of(37))); -// pointService.syncControlNoPower(initDomain(List.of(48))); -// pointService.syncOilBuy(initDomain(List.of(52))); -// gBaseJJDService.pullPoliceInstance(start, end, initDomain(List.of(55,56,57,58))); -// jsbryService.syncPys(initDomain(List.of(59))); -// gBaseSHRWFRService.combatCrime(initDomain(List.of(63))); -// gBaseJJDService.syncPoliceAttack(initDomain(List.of(64))); -// gBaseJJDService.syncHomeViolence(initDomain(List.of(65,66))); -// pointService.syncPointType(initDomain(List.of(67))); -// gBaseSHRWFRService.hadWork(initDomain(List.of(68))); -// gBaseJJDService.syncParentRelation(initDomain(List.of(69,70))); -// gBaseJJDService.syncLove(initDomain(List.of(71))); -// gBaseJJDService.syncMarryDispute(initDomain(List.of(72))); -// gBaseJJDService.syncNeighborAndColleagueDispute(initDomain(List.of(73))); -// gBaseJJDService.syncBullying(initDomain(List.of(74))); -// gBaseSHRWFRService.crimeName(initDomain(List.of(76))); -// pointService.syncIsPetition(initDomain(List.of(111))); -// pointService.syncFatherEducation(initDomain(List.of(112))); -// pointService.syncMotherEducation(initDomain(List.of(113))); -// pointService.syncDomicileType(initDomain(List.of(114))); + pointService.syncSecurity(initDomain(List.of(37))); + habitService.habitModelTask(start, initDomain(List.of(36,60,61,62))); + + pointService.syncCarUser(initDomain(List.of(53))); + riskTaskService.riskAreaModelTask(initDomain(List.of(41))); + pointService.syncScore(initDomain(List.of(43))); + pointService.syncViolence(initDomain(List.of(44))); + noControlService.syncNoControlData(initDomain(List.of(45))); + pointService.syncDrug(initDomain(List.of(37))); + pointService.syncControlNoPower(initDomain(List.of(48))); + pointService.syncOilBuy(initDomain(List.of(52))); + gBaseJJDService.pullPoliceInstance(start, end, initDomain(List.of(55,56,57,58))); + jsbryService.syncPys(initDomain(List.of(59))); + gBaseSHRWFRService.combatCrime(initDomain(List.of(63))); + gBaseJJDService.syncPoliceAttack(initDomain(List.of(64))); + gBaseJJDService.syncHomeViolence(initDomain(List.of(65,66))); + pointService.syncPointType(initDomain(List.of(67))); + gBaseSHRWFRService.hadWork(initDomain(List.of(68))); + gBaseJJDService.syncParentRelation(initDomain(List.of(69,70))); + gBaseJJDService.syncLove(initDomain(List.of(71))); + gBaseJJDService.syncMarryDispute(initDomain(List.of(72))); + gBaseJJDService.syncNeighborAndColleagueDispute(initDomain(List.of(73))); + gBaseJJDService.syncBullying(initDomain(List.of(74))); + gBaseSHRWFRService.crimeName(initDomain(List.of(76))); + pointService.syncIsPetition(initDomain(List.of(111))); + 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.syncAdministrativePunishment(initDomain(List.of(116)));// 需重跑 -// pointService.syncParentsDivorce(initDomain(List.of(117))); -// pointService.syncFamilyDie(initDomain(List.of(118))); -// pointService.syncFatherDie(initDomain(List.of(119))); -// pointService.syncMotherDie(initDomain(List.of(120))); -// pointService.syncChildNo(initDomain(List.of(121))); -// pointService.syncXIDU(initDomain(List.of(122))); -// pointService.syncFiliation(initDomain(List.of(123))); -// // 必须在123后面 -// gBaseJJDService.syncOtherContradict(initDomain(List.of(75))); -// -// pointService.syncPetitionContent(initDomain(List.of(124))); + pointService.syncParentsDivorce(initDomain(List.of(117))); + pointService.syncFamilyDie(initDomain(List.of(118))); + pointService.syncFatherDie(initDomain(List.of(119))); + pointService.syncMotherDie(initDomain(List.of(120))); + pointService.syncChildNo(initDomain(List.of(121))); + pointService.syncXIDU(initDomain(List.of(122))); + pointService.syncFiliation(initDomain(List.of(123))); + // 必须在123后面 + gBaseJJDService.syncOtherContradict(initDomain(List.of(75))); + + pointService.syncPetitionContent(initDomain(List.of(124))); pointService.syncMedicalPressure(initDomain(List.of(125))); pointService.syncSeriousIllness(initDomain(List.of(126))); pointService.syncFamilySeriousIllness(initDomain(List.of(127))); diff --git a/src/main/java/com/biutag/supervisiondata/mapper/wdpc2/WdpcGrjdHyqkbMapper.java b/src/main/java/com/biutag/supervisiondata/mapper/wdpc2/WdpcGrjdHyqkbMapper.java new file mode 100644 index 0000000..86e0cb0 --- /dev/null +++ b/src/main/java/com/biutag/supervisiondata/mapper/wdpc2/WdpcGrjdHyqkbMapper.java @@ -0,0 +1,13 @@ +package com.biutag.supervisiondata.mapper.wdpc2; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.biutag.supervisiondata.pojo.entity.wdpc2.WdpcGrjdHyqkb; +import com.biutag.supervisiondata.pojo.entity.wdpc2.WdpcGrjdJsbry; + +/** + * @author kami on 2024-12-10 17:59:16 + * @version 0.0.1 + * @since 1.8 + */ +public interface WdpcGrjdHyqkbMapper extends BaseMapper { +} diff --git a/src/main/java/com/biutag/supervisiondata/pojo/entity/wdpc2/WdpcGrjdHyqkb.java b/src/main/java/com/biutag/supervisiondata/pojo/entity/wdpc2/WdpcGrjdHyqkb.java new file mode 100644 index 0000000..2cb7263 --- /dev/null +++ b/src/main/java/com/biutag/supervisiondata/pojo/entity/wdpc2/WdpcGrjdHyqkb.java @@ -0,0 +1,25 @@ +package com.biutag.supervisiondata.pojo.entity.wdpc2; + +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.Data; + +import java.io.Serializable; + +/** + * @author kami on 2024-12-10 17:57:58 + * @version 0.0.1 + * @since 1.8 + */ +@Data +@TableName("`wdpc_grjd_jsbry`") +public class WdpcGrjdHyqkb implements Serializable { + @TableField("`id_code`") + String idCode; + @TableField("`name`") + String name; + @TableField("`register_time`") + String registerTime; + @TableField("`status`") + String status; +} diff --git a/src/main/java/com/biutag/supervisiondata/repository/WdpcGrjdHyqkbRepository.java b/src/main/java/com/biutag/supervisiondata/repository/WdpcGrjdHyqkbRepository.java new file mode 100644 index 0000000..43017f2 --- /dev/null +++ b/src/main/java/com/biutag/supervisiondata/repository/WdpcGrjdHyqkbRepository.java @@ -0,0 +1,15 @@ +package com.biutag.supervisiondata.repository; + +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.biutag.supervisiondata.mapper.wdpc2.WdpcGrjdHyqkbMapper; +import com.biutag.supervisiondata.pojo.entity.wdpc2.WdpcGrjdHyqkb; +import org.springframework.stereotype.Service; + +/** + * @author kami on 2024-12-10 17:59:47 + * @version 0.0.1 + * @since 1.8 + */ +@Service +public class WdpcGrjdHyqkbRepository extends ServiceImpl { +}