人员证照

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)));

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<RiskPersonInfo> {
+}

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<WdpcPerson> {
 
     @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);
 }

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

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

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<RiskPersonInfoMapper, RiskPersonInfo> {
+}

src/main/resources/mapper/mine/RiskPersonInfoMapper.xml

@@ -0,0 +1,5 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.biutag.supervisiondata.mapper.mine.RiskPersonInfoMapper">
+
+</mapper>