项目推进提交代码

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

@@ -3688,6 +3688,8 @@ public class TestController {
     private XcrTrustworthyIncentive42Service xcrTrustworthyIncentive42Service;
     @Autowired
     private  XcrDishonestyPunishment19Service xcrDishonestyPunishment19Service;
+    @Autowired
+    private XcrTaxAdministrativePenaltyService xcrTaxAdministrativePenaltyService;
     @GetMapping("/d")
     public String test3(){
 //        xhRequestUtil.requestXinyonghuanhuai();
@@ -3699,7 +3701,8 @@ public class TestController {
 //        xcrOtherInfo38Service.saveDataByUniCode("interface/v1/datawarehouse/list");
 //        xcrOtherInfo39Service.saveDataByUniCode("interface/v1/datawarehouse/list");
 //        xcrTrustworthyIncentive42Service.saveDataByUniCode("interface/v1/datawarehouse/list");
-        xcrDishonestyPunishment19Service.saveDataByUniCode("interface/v1/datawarehouse/list");
+//        xcrDishonestyPunishment19Service.saveDataByUniCode("interface/v1/datawarehouse/list");
+        xcrTaxAdministrativePenaltyService.saveDataByUniCode("gateway/api/1/getLsmcxxByUnscid");
         return "成功";
     }
     @GetMapping("/e")

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

@@ -0,0 +1,109 @@
+package com.zksy.data.domain.po;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.util.Date;
+
+/**
+ * 税务行政处罚（不包括稽查）信息
+ * @TableName xcr_tax_administrative_penalty
+ */
+@TableName(value ="xcr_tax_administrative_penalty")
+@Data
+public class XcrTaxAdministrativePenalty extends BasePo implements Serializable {
+    @JsonProperty("SSWFXWDJUUID")
+    @TableField("SSWFXWDJUUID")
+    private String sswfxwdjuuid;
+
+    // 税务行政处罚决定书唯一标识
+    @JsonProperty("SWXZCFJDSUUID")
+    @TableField("SWXZCFJDSUUID")
+    private String swxzcfjdssuuid;
+
+    // 登记序号
+    @JsonProperty("DJXH")
+    @TableField("DJXH")
+    private Integer djxh;
+
+    // 纳税人识别号
+    @JsonProperty("NSRSBH")
+    @TableField("NSRSBH")
+    private String nsrsbh;
+
+    // 纳税人名称
+    @JsonProperty("NSRMC")
+    @TableField("NSRMC")
+    private String nsrmc;
+
+    // 违法行为名称
+    @JsonProperty("WFXWMC")
+    @TableField("WFXWMC")
+    private String wfxwmc;
+
+    // 税收违法类型
+    @JsonProperty("SSWFLXMC")
+    @TableField("SSWFLXMC")
+    private String sswflxmc;
+
+    // 税收违法手段
+    @JsonProperty("WFSD")
+    @TableField("WFSD")
+    private String wfsd;
+
+    // 处罚程序
+    @JsonProperty("CFCD")
+    @TableField("CFCD")
+    private String cfcd;
+
+    // 违法事实
+    @JsonProperty("WFSS")
+    @TableField("WFSS")
+    private String wfss;
+
+    // 处罚依据
+    @JsonProperty("CFYJ")
+    @TableField("CFYJ")
+    private String cfyj;
+
+    // 字轨
+    @JsonProperty("ZG")
+    @TableField("ZG")
+    private String zg;
+
+    // 应缴罚款金额
+    @JsonProperty("YJFKJE")
+    @TableField("YJFKJE")
+    private BigDecimal yjfkje;
+
+    // 文书制作日期
+    @JsonProperty("WSZZRQ")
+    @TableField("WSZZRQ")
+    private Date wszzrq;
+
+    // 主管税务机关
+    @JsonProperty("SWJGMC")
+    @TableField("SWJGMC")
+    private String swjgmc;
+
+    // 归属区域
+    @JsonProperty("GSQX")
+    @TableField("GSQX")
+    private String gsqx;
+
+    // 时间戳
+    @JsonProperty("ENTERINGTIME")
+    @TableField("ENTERINGTIME")
+    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date enteringtime;
+
+    // 更新标志位
+    @JsonProperty("OPTYPE")
+    @TableField("OPTYPE")
+    private Byte optype;
+}

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

@@ -0,0 +1,6 @@
+package com.zksy.data.domain.response;
+
+import com.zksy.common.domain.response.BaseResponse;
+
+public class XcrTaxAdministrativePenaltyResponse extends BaseResponse {
+}

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

@@ -0,0 +1,18 @@
+package com.zksy.data.mapper;
+
+import com.zksy.data.domain.po.XcrTaxAdministrativePenalty;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author Administrator
+* @description 针对表【xcr_tax_administrative_penalty(税务行政处罚（不包括稽查）信息)】的数据库操作Mapper
+* @createDate 2024-10-15 15:28:19
+* @Entity com.zksy.data.domain.po.XcrTaxAdministrativePenalty
+*/
+public interface XcrTaxAdministrativePenaltyMapper extends BaseMapper<XcrTaxAdministrativePenalty> {
+
+}
+
+
+
+

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

@@ -0,0 +1,13 @@
+package com.zksy.data.service;
+
+import com.zksy.data.domain.po.XcrTaxAdministrativePenalty;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author Administrator
+* @description 针对表【xcr_tax_administrative_penalty(税务行政处罚（不包括稽查）信息)】的数据库操作Service
+* @createDate 2024-10-15 15:28:19
+*/
+public interface XcrTaxAdministrativePenaltyService extends IService<XcrTaxAdministrativePenalty>,IBaseSaveDataInterface {
+
+}

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

@@ -0,0 +1,56 @@
+package com.zksy.data.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.zksy.data.domain.po.XcrTaxAdministrativePenalty;
+import com.zksy.data.domain.response.XcrTaxAdministrativePenaltyResponse;
+import com.zksy.data.mapper.XcrTaxAdministrativePenaltyMapper;
+import com.zksy.data.service.XcrTaxAdministrativePenaltyService;
+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.List;
+import java.util.Vector;
+
+/**
+* @author Administrator
+* @description 针对表【xcr_tax_administrative_penalty(税务行政处罚（不包括稽查）信息)】的数据库操作Service实现
+* @createDate 2024-10-15 15:28:19
+*/
+@Service
+@Slf4j
+public class XcrTaxAdministrativePenaltyServiceImpl extends ServiceImpl<XcrTaxAdministrativePenaltyMapper, XcrTaxAdministrativePenalty>
+    implements XcrTaxAdministrativePenaltyService{
+    @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<XcrTaxAdministrativePenalty> toDatabaseList = new Vector<>();
+        creditCodes.parallelStream().forEach(creditCode -> {
+            List<XcrTaxAdministrativePenalty> list = xhRequestUtil.httpRequestByUniCode(creditCode, address,
+                    XcrTaxAdministrativePenaltyResponse.class,
+                    XcrTaxAdministrativePenalty.class,
+                    "SHXYDM"
+            );
+            if(list != null){
+                toDatabaseList.addAll(list);
+            }
+        });
+        this.remove(null);
+        this.saveBatch(toDatabaseList);
+        log.info("税务行政处罚(不包括稽查)信息同步完成");
+    }
+}
+
+
+
+

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

@@ -0,0 +1,38 @@
+<?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.XcrTaxAdministrativePenaltyMapper">
+
+    <resultMap id="BaseResultMap" type="com.zksy.data.domain.po.XcrTaxAdministrativePenalty">
+            <result property="sswfxwdjuuid" column="SSWFXWDJUUID" jdbcType="VARCHAR"/>
+            <result property="swxzcfjdsuuid" column="SWXZCFJDSUUID" jdbcType="VARCHAR"/>
+            <result property="djxh" column="DJXH" jdbcType="INTEGER"/>
+            <result property="nsrsbh" column="NSRSBH" jdbcType="VARCHAR"/>
+            <result property="nsrmc" column="NSRMC" jdbcType="VARCHAR"/>
+            <result property="wfxwmc" column="WFXWMC" jdbcType="VARCHAR"/>
+            <result property="sswflxmc" column="SSWFLXMC" jdbcType="VARCHAR"/>
+            <result property="wfsd" column="WFSD" jdbcType="VARCHAR"/>
+            <result property="cfcd" column="CFCD" jdbcType="VARCHAR"/>
+            <result property="wfss" column="WFSS" jdbcType="VARCHAR"/>
+            <result property="cfyj" column="CFYJ" jdbcType="VARCHAR"/>
+            <result property="zg" column="ZG" jdbcType="VARCHAR"/>
+            <result property="yjfkje" column="YJFKJE" jdbcType="DECIMAL"/>
+            <result property="wszzrq" column="WSZZRQ" jdbcType="DATE"/>
+            <result property="swjgmc" column="SWJGMC" jdbcType="VARCHAR"/>
+            <result property="gsqx" column="GSQX" jdbcType="VARCHAR"/>
+            <result property="enteringtime" column="ENTERINGTIME" jdbcType="TIMESTAMP"/>
+            <result property="optype" column="OPTYPE" jdbcType="TINYINT"/>
+            <result property="uniCode" column="uni_code" jdbcType="VARCHAR"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        SSWFXWDJUUID,SWXZCFJDSUUID,DJXH,
+        NSRSBH,NSRMC,WFXWMC,
+        SSWFLXMC,WFSD,CFCD,
+        WFSS,CFYJ,ZG,
+        YJFKJE,WSZZRQ,SWJGMC,
+        GSQX,ENTERINGTIME,OPTYPE,
+        uni_code
+    </sql>
+</mapper>