diff --git a/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java b/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java index d2ffd52..2bab7b2 100644 --- a/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java +++ b/src/main/java/com/biutag/supervisiondata/event/ApplicationEvent.java @@ -110,8 +110,8 @@ public class ApplicationEvent { // personalService.pullPetitionAgain(); // pointService.personPullAndSave(start, end); // gBaseJJDService.pullAndSave(start, end); - riskPersonalService.fixed(); - personalService.syncPerson(); +// riskPersonalService.fixed(); +// personalService.syncPerson(); // // petitionService.petitionModelTask(initDomain(List.of(40))); // riskTaskService.eduModelTask(initDomain(List.of(34))); diff --git a/src/main/java/com/biutag/supervisiondata/mapper/mine/RiskPersonInfoMapper.java b/src/main/java/com/biutag/supervisiondata/mapper/mine/RiskPersonInfoMapper.java new file mode 100644 index 0000000..db51602 --- /dev/null +++ b/src/main/java/com/biutag/supervisiondata/mapper/mine/RiskPersonInfoMapper.java @@ -0,0 +1,12 @@ +package com.biutag.supervisiondata.mapper.mine; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.biutag.supervisiondata.pojo.entity.mine.RiskPersonInfo; + +/** + * @author kami on 2024-12-12 10:30:34 + * @version 0.0.1 + * @since 1.8 + */ +public interface RiskPersonInfoMapper extends BaseMapper { +} diff --git a/src/main/java/com/biutag/supervisiondata/mapper/wdpc/WdpcPersonMapper.java b/src/main/java/com/biutag/supervisiondata/mapper/wdpc/WdpcPersonMapper.java index 469c05d..7a1e820 100644 --- a/src/main/java/com/biutag/supervisiondata/mapper/wdpc/WdpcPersonMapper.java +++ b/src/main/java/com/biutag/supervisiondata/mapper/wdpc/WdpcPersonMapper.java @@ -2,6 +2,8 @@ package com.biutag.supervisiondata.mapper.wdpc; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.biutag.supervisiondata.pojo.entity.wdpc.WdpcPerson; +import org.apache.ibatis.annotations.Param; +import org.apache.ibatis.annotations.Select; import org.apache.ibatis.annotations.Update; /** @@ -13,4 +15,12 @@ public interface WdpcPersonMapper extends BaseMapper { @Update("truncate table wdpc_person") int truncateTable(); + + @Select(" select count(b.id_code) from dwd_ry_qbpt_sfzzzxx as a inner join csga_wdpcdb.wdpc_person as b \n" + + "on a.GMSFHM = b.id_code ") + int selectPersonImageCount(); + + @Select(" select a.GMSFHM as idCode,a.sdxp as image from dwd_ry_qbpt_sfzzzxx as a inner join csga_wdpcdb.wdpc_person as b \n" + + "on a.GMSFHM = b.id_code ") + int selectPersonImagePage(@Param("pageNo")Integer pageNo, @Param("pageSize")Integer pageSize); } diff --git a/src/main/java/com/biutag/supervisiondata/pojo/domain/PersonImageInfo.java b/src/main/java/com/biutag/supervisiondata/pojo/domain/PersonImageInfo.java new file mode 100644 index 0000000..daffe44 --- /dev/null +++ b/src/main/java/com/biutag/supervisiondata/pojo/domain/PersonImageInfo.java @@ -0,0 +1,18 @@ +package com.biutag.supervisiondata.pojo.domain; + +import lombok.Data; + +import java.io.Serializable; + +/** + * @author kami on 2024-12-12 10:38:25 + * @version 0.0.1 + * @since 1.8 + */ +@Data +public class PersonImageInfo implements Serializable { + + String idCode; + + byte[] image; +} diff --git a/src/main/java/com/biutag/supervisiondata/pojo/entity/mine/RiskPersonInfo.java b/src/main/java/com/biutag/supervisiondata/pojo/entity/mine/RiskPersonInfo.java new file mode 100644 index 0000000..af9c0a9 --- /dev/null +++ b/src/main/java/com/biutag/supervisiondata/pojo/entity/mine/RiskPersonInfo.java @@ -0,0 +1,27 @@ +package com.biutag.supervisiondata.pojo.entity.mine; + +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.Data; + +import java.io.Serial; +import java.io.Serializable; + +/** + * @author kami on 2024-12-12 10:28:30 + * @version 0.0.1 + * @since 1.8 + */ +@Data +@TableName("`risk_person_info`") +public class RiskPersonInfo implements Serializable { + + @Serial + private static final long serialVersionUID = 1L; + + @TableId(value = "`id_code`") + String idCode; + @TableField(value = "`image_base64`") + String imageBase64; +} diff --git a/src/main/java/com/biutag/supervisiondata/repository/RiskPersonInfoRepository.java b/src/main/java/com/biutag/supervisiondata/repository/RiskPersonInfoRepository.java new file mode 100644 index 0000000..ff62178 --- /dev/null +++ b/src/main/java/com/biutag/supervisiondata/repository/RiskPersonInfoRepository.java @@ -0,0 +1,15 @@ +package com.biutag.supervisiondata.repository; + +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.biutag.supervisiondata.mapper.mine.RiskPersonInfoMapper; +import com.biutag.supervisiondata.pojo.entity.mine.RiskPersonInfo; +import org.springframework.stereotype.Service; + +/** + * @author kami on 2024-12-12 10:37:26 + * @version 0.0.1 + * @since 1.8 + */ +@Service +public class RiskPersonInfoRepository extends ServiceImpl { +} diff --git a/src/main/resources/mapper/mine/RiskPersonInfoMapper.xml b/src/main/resources/mapper/mine/RiskPersonInfoMapper.xml new file mode 100644 index 0000000..d521a30 --- /dev/null +++ b/src/main/resources/mapper/mine/RiskPersonInfoMapper.xml @@ -0,0 +1,5 @@ + + + + +