supervision
/
supervision-data
5
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
Browse Source

Merge remote-tracking branch 'origin/master'

master
sjh 1 year ago
parent
c2d347b717 ebfb11a60d
commit
ccaac336cd
4 changed files with 104 additions and 55 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Unified View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 106
      src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java
  2. 13
      src/main/java/com/biutag/supervisiondata/mapper/wdpc2/WdpcGrjdHyqkbMapper.java
  3. 25
      src/main/java/com/biutag/supervisiondata/pojo/entity/wdpc2/WdpcGrjdHyqkb.java
  4. 15
      src/main/java/com/biutag/supervisiondata/repository/WdpcGrjdHyqkbRepository.java

106
src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java
Unescape View File

@ -104,65 +104,61 @@ public class ApplicationEvent {
CompletableFutureUtil.runSync(() -> { CompletableFutureUtil.runSync(() -> {
// 测试数据 // 测试数据
// gBaseJJDService.pullDataAndSaveRedis(start, end); // gBaseJJDService.pullDataAndSaveRedis(start, end);
personalService.init();
personalService.pullInvestigate();
// personalService.init(); personalService.pullPsychosis();
// personalService.pullInvestigate(); gBaseJJDService.pullAndSave(start, end);
// personalService.pullPsychosis(); gBaseSHRWFRService.pullAndSave(start, end);
// gBaseJJDService.pullAndSave(start, end); petitionService.personPullAndSave(start, end);
// gBaseSHRWFRService.pullAndSave(start, end); personalService.pullPetitionAgain();
// petitionService.personPullAndSave(start, end); pointService.personPullAndSave(start, end);
// personalService.pullPetitionAgain();
// pointService.personPullAndSave(start, end);
riskPersonalService.fixed(); riskPersonalService.fixed();
//
// petitionService.petitionModelTask(initDomain(List.of(40)));
// riskTaskService.eduModelTask(initDomain(List.of(34)));
// petitionService.petitionModelTask(initDomain(List.of(40))); riskTaskService.infoModelTask(initDomain(List.of(32,33)));
// riskTaskService.eduModelTask(initDomain(List.of(34)));
// riskTaskService.infoModelTask(initDomain(List.of(32,33)));
// marriageService.marriageModelTask(initDomain(List.of(39,51))); // marriageService.marriageModelTask(initDomain(List.of(39,51)));
// pointService.syncSecurity(initDomain(List.of(37))); pointService.syncSecurity(initDomain(List.of(37)));
// habitService.habitModelTask(start, initDomain(List.of(36,60,61,62))); habitService.habitModelTask(start, initDomain(List.of(36,60,61,62)));
//
// pointService.syncCarUser(initDomain(List.of(53))); pointService.syncCarUser(initDomain(List.of(53)));
// riskTaskService.riskAreaModelTask(initDomain(List.of(41))); riskTaskService.riskAreaModelTask(initDomain(List.of(41)));
// pointService.syncScore(initDomain(List.of(43))); pointService.syncScore(initDomain(List.of(43)));
// pointService.syncViolence(initDomain(List.of(44))); pointService.syncViolence(initDomain(List.of(44)));
// noControlService.syncNoControlData(initDomain(List.of(45))); noControlService.syncNoControlData(initDomain(List.of(45)));
// pointService.syncDrug(initDomain(List.of(37))); pointService.syncDrug(initDomain(List.of(37)));
// pointService.syncControlNoPower(initDomain(List.of(48))); pointService.syncControlNoPower(initDomain(List.of(48)));
// pointService.syncOilBuy(initDomain(List.of(52))); pointService.syncOilBuy(initDomain(List.of(52)));
// gBaseJJDService.pullPoliceInstance(start, end, initDomain(List.of(55,56,57,58))); gBaseJJDService.pullPoliceInstance(start, end, initDomain(List.of(55,56,57,58)));
// jsbryService.syncPys(initDomain(List.of(59))); jsbryService.syncPys(initDomain(List.of(59)));
// gBaseSHRWFRService.combatCrime(initDomain(List.of(63))); gBaseSHRWFRService.combatCrime(initDomain(List.of(63)));
// gBaseJJDService.syncPoliceAttack(initDomain(List.of(64))); gBaseJJDService.syncPoliceAttack(initDomain(List.of(64)));
// gBaseJJDService.syncHomeViolence(initDomain(List.of(65,66))); gBaseJJDService.syncHomeViolence(initDomain(List.of(65,66)));
// pointService.syncPointType(initDomain(List.of(67))); pointService.syncPointType(initDomain(List.of(67)));
// gBaseSHRWFRService.hadWork(initDomain(List.of(68))); gBaseSHRWFRService.hadWork(initDomain(List.of(68)));
// gBaseJJDService.syncParentRelation(initDomain(List.of(69,70))); gBaseJJDService.syncParentRelation(initDomain(List.of(69,70)));
// gBaseJJDService.syncLove(initDomain(List.of(71))); gBaseJJDService.syncLove(initDomain(List.of(71)));
// gBaseJJDService.syncMarryDispute(initDomain(List.of(72))); gBaseJJDService.syncMarryDispute(initDomain(List.of(72)));
// gBaseJJDService.syncNeighborAndColleagueDispute(initDomain(List.of(73))); gBaseJJDService.syncNeighborAndColleagueDispute(initDomain(List.of(73)));
// gBaseJJDService.syncBullying(initDomain(List.of(74))); gBaseJJDService.syncBullying(initDomain(List.of(74)));
// gBaseSHRWFRService.crimeName(initDomain(List.of(76))); gBaseSHRWFRService.crimeName(initDomain(List.of(76)));
// pointService.syncIsPetition(initDomain(List.of(111))); pointService.syncIsPetition(initDomain(List.of(111)));
// pointService.syncFatherEducation(initDomain(List.of(112))); pointService.syncFatherEducation(initDomain(List.of(112)));
// pointService.syncMotherEducation(initDomain(List.of(113))); pointService.syncMotherEducation(initDomain(List.of(113)));
// pointService.syncDomicileType(initDomain(List.of(114))); 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.syncAdministrativePunishment(initDomain(List.of(116)));// 需重跑
// pointService.syncParentsDivorce(initDomain(List.of(117))); pointService.syncParentsDivorce(initDomain(List.of(117)));
// pointService.syncFamilyDie(initDomain(List.of(118))); pointService.syncFamilyDie(initDomain(List.of(118)));
// pointService.syncFatherDie(initDomain(List.of(119))); pointService.syncFatherDie(initDomain(List.of(119)));
// pointService.syncMotherDie(initDomain(List.of(120))); pointService.syncMotherDie(initDomain(List.of(120)));
// pointService.syncChildNo(initDomain(List.of(121))); pointService.syncChildNo(initDomain(List.of(121)));
// pointService.syncXIDU(initDomain(List.of(122))); pointService.syncXIDU(initDomain(List.of(122)));
// pointService.syncFiliation(initDomain(List.of(123))); pointService.syncFiliation(initDomain(List.of(123)));
// // 必须在123后面 // 必须在123后面
// gBaseJJDService.syncOtherContradict(initDomain(List.of(75))); gBaseJJDService.syncOtherContradict(initDomain(List.of(75)));
//
// pointService.syncPetitionContent(initDomain(List.of(124))); pointService.syncPetitionContent(initDomain(List.of(124)));
pointService.syncMedicalPressure(initDomain(List.of(125))); pointService.syncMedicalPressure(initDomain(List.of(125)));
pointService.syncSeriousIllness(initDomain(List.of(126))); pointService.syncSeriousIllness(initDomain(List.of(126)));
pointService.syncFamilySeriousIllness(initDomain(List.of(127))); pointService.syncFamilySeriousIllness(initDomain(List.of(127)));

13
src/main/java/com/biutag/supervisiondata/mapper/wdpc2/WdpcGrjdHyqkbMapper.java
Unescape View File

@ -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<WdpcGrjdHyqkb> {
}

25
src/main/java/com/biutag/supervisiondata/pojo/entity/wdpc2/WdpcGrjdHyqkb.java
Unescape View File

@ -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;
}

15
src/main/java/com/biutag/supervisiondata/repository/WdpcGrjdHyqkbRepository.java
Unescape View File

@ -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<WdpcGrjdHyqkbMapper, WdpcGrjdHyqkb> {
}
Write Preview
Loading…
Cancel
Save