非正常户解除信息表数据采集

data-service/src/main/java/com/zksy/data/controller/TestController.java

@@ -46,6 +46,8 @@ public class TestController {
     @Autowired
     private XcrHistoricalLegalRepresentativeService xcrHistoricalLegalRepresentativeService;
     @Autowired
+    private XcrAbnormalHouseholdTerminationService xcrAbnormalHouseholdTerminationService;
+    @Autowired
     private XcrTaxAdministrativePenaltyService xcrTaxAdministrativePenaltyService;
     @GetMapping("/a")
     public String hello(){
@@ -61,8 +63,9 @@ public class TestController {
 //        xcrNonNaturalPersonContributionService.saveDataByUniCode("gateway/api/1/getFzrrczxxByUniscid");
 //        xcrNaturalPersonContributionsService.saveDataByUniCode("gateway/api/1/getZrrczxxByUniscid");
 //        xcrHistoryNameService.saveDataByUniCode("gateway/api/1/getLsmcxxByUnscid");
-        xcrHistoricalLegalRepresentativeService.saveDataByUniCode("gateway/api/1/getLsfddbrxxByUniscid");
-//        xcrTaxAdministrativePenaltyService.saveDataByUniCode("gateway/api/1/getLsmcxxByUnscid");
+//        xcrHistoricalLegalRepresentativeService.saveDataByUniCode("gateway/api/1/getLsfddbrxxByUniscid");
+//        xcrAbnormalHouseholdTerminationService.saveDataByUniCode("gateway/api/1/getFzchjcxxByUniscid");
+//        xcrTaxAdministrativePenaltyService.saveDataByUniCode("gateway/api/1/getSwxzcfxxByUniscid");
         return "成功";
     }
     @GetMapping("/b")
@@ -86,7 +89,7 @@ public class TestController {
     private RedisService redisService;
     @GetMapping("/c")
     public String test2(){
-                List<String> creditCodes = Arrays.asList("91431227MA4QPUTX06",
+                List<String> creditCodes = Arrays.asList("91431227MA4L8B5E3N","91431227MA4QPUTX06",
                 "91431227MABT9WPU4T",
                 "91431227MABR5P9A6A",
                 "91431227MACAF2XEXC",

data-service/src/main/java/com/zksy/data/domain/po/XcrAbnormalHouseholdTermination.java

@@ -0,0 +1,79 @@
+package com.zksy.data.domain.po;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.io.Serializable;
+import java.util.Date;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+/**
+ * 非正常户解除信息表
+ * @TableName xcr_abnormal_household_termination
+ */
+@TableName(value ="xcr_abnormal_household_termination")
+@Data
+public class XcrAbnormalHouseholdTermination extends BasePo implements Serializable {
+    // 非正常户认定唯一标识
+    @JsonProperty("FZCHRDUUID")
+    @TableField("FZCHRDUUID")
+    private String FZCHRDUUID;
+
+    // 纳税人识别号
+    @JsonProperty("NSRSBH")
+    @TableField("NSRSBH")
+    private String NSRSBH;
+
+    // 纳税人名称
+    @JsonProperty("NSRMC")
+    @TableField("NSRMC")
+    private String NSRMC;
+
+    // 纳税人状态
+    @JsonProperty("NSRZTMC")
+    @TableField("NSRZTMC")
+    private String NSRZTMC;
+
+    // 认定原因
+    @JsonProperty("RDYY")
+    @TableField("RDYY")
+    private String RDYY;
+
+    // 认定日期
+    @JsonProperty("RDRQ")
+    @TableField("RDRQ")
+    private Date RDRQ;
+
+    // 认定税务机关
+    @JsonProperty("RDSWJG")
+    @TableField("RDSWJG")
+    private String RDSWJG;
+
+    // 解除非正常户日期
+    @JsonProperty("JCFZCHRQ")
+    @TableField("JCFZCHRQ")
+    private Date JCFZCHRQ;
+
+    // 解除税务机关
+    @JsonProperty("JCFZCSWJG")
+    @TableField("JCFZCSWJG")
+    private String JCFZCSWJG;
+
+    // 时间戳
+    @JsonProperty("ENTERINGTIME")
+    @TableField("ENTERINGTIME")
+    private Date ENTERINGTIME;
+
+    // 更新标志位
+    @JsonProperty("OPTYPE")
+    @TableField("OPTYPE")
+    private Integer OPTYPE;
+
+    // 插入时间
+    @JsonProperty("I_TIME")
+    @TableField("I_TIME")
+    private Date I_TIME;
+}

data-service/src/main/java/com/zksy/data/domain/response/XcrAbnormalHouseholdTerminationResponse.java

@@ -0,0 +1,12 @@
+package com.zksy.data.domain.response;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.zksy.common.domain.response.BaseResponse;
+import com.zksy.data.domain.po.XcrAbnormalHouseholdTermination;
+
+import java.util.List;
+
+public class XcrAbnormalHouseholdTerminationResponse extends BaseResponse {
+    @JsonProperty("data")
+    private List<XcrAbnormalHouseholdTermination> data;
+}

data-service/src/main/java/com/zksy/data/mapper/XcrAbnormalHouseholdTerminationMapper.java

@@ -0,0 +1,18 @@
+package com.zksy.data.mapper;
+
+import com.zksy.data.domain.po.XcrAbnormalHouseholdTermination;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author 邵洋
+* @description 针对表【xcr_abnormal_household_termination(非正常户解除信息表)】的数据库操作Mapper
+* @createDate 2024-10-15 15:31:32
+* @Entity com.zksy.data.domain.po.XcrAbnormalHouseholdTermination
+*/
+public interface XcrAbnormalHouseholdTerminationMapper extends BaseMapper<XcrAbnormalHouseholdTermination> {
+
+}
+
+
+
+

data-service/src/main/java/com/zksy/data/service/XcrAbnormalHouseholdTerminationService.java

@@ -0,0 +1,13 @@
+package com.zksy.data.service;
+
+import com.zksy.data.domain.po.XcrAbnormalHouseholdTermination;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author 邵洋
+* @description 针对表【xcr_abnormal_household_termination(非正常户解除信息表)】的数据库操作Service
+* @createDate 2024-10-15 15:31:32
+*/
+public interface XcrAbnormalHouseholdTerminationService extends IService<XcrAbnormalHouseholdTermination>,IBaseSaveDataInterface {
+
+}

data-service/src/main/java/com/zksy/data/service/impl/XcrAbnormalHouseholdTerminationServiceImpl.java

@@ -0,0 +1,62 @@
+package com.zksy.data.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.zksy.data.domain.po.XcrAbnormalHouseholdTermination;
+import com.zksy.data.domain.po.XcrAdministrativeLicensing;
+import com.zksy.data.domain.po.XcrSupplementaryForeignInvestment;
+import com.zksy.data.domain.response.XcrAbnormalHouseholdTerminationResponse;
+import com.zksy.data.domain.response.XcrAdministrativeLicensingResponse;
+import com.zksy.data.domain.response.XcrSupplementaryForeignInvestmentResponse;
+import com.zksy.data.service.XcrAbnormalHouseholdTerminationService;
+import com.zksy.data.mapper.XcrAbnormalHouseholdTerminationMapper;
+import com.zksy.data.utils.RedisService;
+import com.zksy.data.utils.XhRequestUtil;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Vector;
+
+/**
+* @author 邵洋
+* @description 针对表【xcr_abnormal_household_termination(非正常户解除信息表)】的数据库操作Service实现
+* @createDate 2024-10-15 15:31:32
+*/
+@Service
+@Slf4j
+public class XcrAbnormalHouseholdTerminationServiceImpl extends ServiceImpl<XcrAbnormalHouseholdTerminationMapper, XcrAbnormalHouseholdTermination>
+    implements XcrAbnormalHouseholdTerminationService{
+
+    @Autowired
+    private XhRequestUtil xhRequestUtil;
+    @Autowired
+    private RedisService redisService;
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void saveDataByUniCode(String address) {
+        //模拟从数据库中取数据大约为3000-4000条
+        List<String> creditCodes = (List<String>) redisService.getList("creditCodes").get(0);
+        Vector<XcrAbnormalHouseholdTermination> toDatabaseList = new Vector<>();
+        creditCodes.parallelStream().forEach(creditCode -> {
+            List<XcrAbnormalHouseholdTermination> list = xhRequestUtil.httpRequestByUniCode(creditCode, address,
+                    XcrAbnormalHouseholdTerminationResponse.class,
+                    XcrAbnormalHouseholdTermination.class,
+                    "SHXYDM"
+            );
+            if(list != null){
+                toDatabaseList.addAll(list);
+            }
+        });
+        this.remove(null);
+        this.saveBatch(toDatabaseList);
+        log.info("非正常户解除信息表");
+    }
+}
+
+
+
+

data-service/src/main/resources/mapper/XcrAbnormalHouseholdTerminationMapper.xml

@@ -0,0 +1,30 @@
+<?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.zksy.data.mapper.XcrAbnormalHouseholdTerminationMapper">
+
+    <resultMap id="BaseResultMap" type="com.zksy.data.domain.po.XcrAbnormalHouseholdTermination">
+            <result property="FZCHRDUUID" column="FZCHRDUUID" jdbcType="VARCHAR"/>
+            <result property="NSRSBH" column="NSRSBH" jdbcType="VARCHAR"/>
+            <result property="NSRMC" column="NSRMC" jdbcType="VARCHAR"/>
+            <result property="NSRZTMC" column="NSRZTMC" jdbcType="VARCHAR"/>
+            <result property="RDYY" column="RDYY" jdbcType="VARCHAR"/>
+            <result property="RDRQ" column="RDRQ" jdbcType="DATE"/>
+            <result property="RDSWJG" column="RDSWJG" jdbcType="VARCHAR"/>
+            <result property="JCFZCHRQ" column="JCFZCHRQ" jdbcType="DATE"/>
+            <result property="JCFZCSWJG" column="JCFZCSWJG" jdbcType="VARCHAR"/>
+            <result property="ENTERINGTIME" column="ENTERINGTIME" jdbcType="TIMESTAMP"/>
+            <result property="OPTYPE" column="OPTYPE" jdbcType="TINYINT"/>
+            <result property="I_TIME" column="I_TIME" jdbcType="TIMESTAMP"/>
+            <result property="uniCode" column="uni_code" jdbcType="VARCHAR"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        FZCHRDUUID,NSRSBH,NSRMC,
+        NSRZTMC,RDYY,RDRQ,
+        RDSWJG,JCFZCHRQ,JCFZCSWJG,
+        ENTERINGTIME,OPTYPE,I_TIME,
+        uni_code
+    </sql>
+</mapper>