项目推进提交代码

data-service/src/main/java/com/zksy/data/constant/RedisKeyConstant.java

@@ -0,0 +1,5 @@
+package com.zksy.data.constant;
+
+public class RedisKeyConstant {
+    public static final String HUAIHUA_TOKEN_KEY = "xinyonghuaihua:token";
+}

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

@@ -30,6 +30,18 @@ public class TestController {
     private XcrAgriculturalSupplementService xcrAgriculturalSupplementService;
     @Autowired
     private XcrDomesticCapitalSupplementService xcrDomesticCapitalSupplementService;
+    @Autowired
+    private XcrInstallmentPaymentService xcrInstallmentPaymentService;
+    @Autowired
+    private XcrInvestorSubscriptionDetailsService xcrInvestorSubscriptionDetailsService;
+    @Autowired
+    private XcrNonNaturalPersonContributionService xcrNonNaturalPersonContributionService;
+    @Autowired
+    private XcrNaturalPersonContributionsService xcrNaturalPersonContributionsService;
+    @Autowired
+    private XcrHistoryNameService xcrHistoryNameService;
+    @Autowired
+    private XcrHistoricalLegalRepresentativeService xcrHistoricalLegalRepresentativeService;
     @GetMapping("/a")
     public String hello(){
 //        xcrELicNcertificateService.saveDataByUniCode("gateway/api/1/getXzxkxxByUniscid");
@@ -38,16 +50,22 @@ public class TestController {
 //        xcrSupplementaryForeignInvestmentService.saveDataByUniCode("gateway/api/1/getWzbcxxByUniscid");
 //        xcrAppointDelegatesService.saveDataByUniCode("gateway/api/1/getWpdbxxByUniscid");
 //        xcrAgriculturalSupplementService.saveDataByUniCode("gateway/api/1/getNzbcxxByUniscid");
-        xcrDomesticCapitalSupplementService.saveDataByUniCode("gateway/api/1/getNzbcxxByUniscid1");
+//        xcrDomesticCapitalSupplementService.saveDataByUniCode("gateway/api/1/getNzbcxxByUniscid1");
+//        xcrInstallmentPaymentService.saveDataByUniCode("gateway/api/1/getFqsjxxByUniscid");
+//        xcrInvestorSubscriptionDetailsService.saveDataByUniCode("gateway/api/1/getTzrrjxxByUniscid");
+//        xcrNonNaturalPersonContributionService.saveDataByUniCode("gateway/api/1/getFzrrczxxByUniscid");
+//        xcrNaturalPersonContributionsService.saveDataByUniCode("gateway/api/1/getZrrczxxByUniscid");
+//        xcrHistoryNameService.saveDataByUniCode("gateway/api/1/getLsmcxxByUnscid");
+        xcrHistoricalLegalRepresentativeService.saveDataByUniCode("gateway/api/1/getLsfddbrxxByUniscid");
         return "成功";
     }
     @GetMapping("/b")
-    public String test(String address){
+    public String test(String address,String paramsValue){
         List<String> creditCodes = (List<String>) redisService.getList("creditCodes").get(0);
         for (String creditCode : creditCodes) {
             String s;
             try {
-                s = xhRequestUtil.testHttpRequest(creditCode, address);
+                s = xhRequestUtil.testHttpRequest(creditCode, address,paramsValue);
             } catch (Exception e) {
                 break;
             }
@@ -3649,4 +3667,9 @@ public class TestController {
         redisService.saveList("creditCodes",creditCodes);
         return "成功";
     }
+    @GetMapping("/d")
+    public String test3(){
+        xhRequestUtil.requestXinyonghuanhuai();
+        return "成功";
+    }
 }

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

@@ -6,66 +6,45 @@ import com.fasterxml.jackson.annotation.JsonProperty;
 import lombok.Data;
 
 import java.io.Serializable;
-import java.math.BigDecimal;
 import java.util.Date;
 
 @Data
 public class Temp extends BasePo implements Serializable {
 
-    @TableField("POSTALCODE")
-    @JsonProperty("POSTALCODE")
-    private String POSTALCODE;
+    @JsonProperty("CODE")
+    @TableField("CODE")
+    private int CODE;
 
-    @TableField("GOVPORP")
-    @JsonProperty("GOVPORP")
-    private BigDecimal GOVPORP;
+    @JsonProperty("MESSAGE")
+    @TableField("MESSAGE")
+    private String MESSAGE;
 
-    @TableField("YIEDISTRICT")
-    @JsonProperty("YIEDISTRICT")
-    private String YIEDISTRICT;
+    @JsonProperty("CERTYPE")
+    @TableField("CERTYPE")
+    private String CERTYPE;
 
-    @TableField("EMAIL")
-    @JsonProperty("EMAIL")
-    private String EMAIL;
+    @JsonProperty("CERNO")
+    @TableField("CERNO")
+    private String CERNO;
 
-    @TableField("PRIPID")
-    @JsonProperty("PRIPID")
-    private String PRIPID;
-
-    @TableField("LOCALADM")
-    @JsonProperty("LOCALADM")
-    private String LOCALADM;
+    @JsonProperty("HISNAMEID")
+    @TableField("HISNAMEID")
+    private String HISNAMEID;
 
-    @TableField("GOVNUM")
-    @JsonProperty("GOVNUM")
-    private Integer GOVNUM;
-
-    @TableField("TEL")
-    @JsonProperty("TEL")
-    private String TEL;
-
-    @TableField("FARMERNUM")
-    @JsonProperty("FARMERNUM")
-    private Integer FARMERNUM;
-
-    @TableField("ETPS_ID")
     @JsonProperty("ETPS_ID")
+    @TableField("ETPS_ID")
     private String ETPS_ID;
 
-    @TableField("FARMERPORP")
-    @JsonProperty("FARMERPORP")
-    private BigDecimal FARMERPORP;
+    @JsonProperty("PRIPID")
+    @TableField("PRIPID")
+    private String PRIPID;
 
+    @JsonProperty("S_EXT_DATATIME")
     @TableField("S_EXT_DATATIME")
     @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd HH:mm:ss")
-    @JsonProperty("S_EXT_DATATIME")
     private Date S_EXT_DATATIME;
 
-    @TableField("PROLOC")
-    @JsonProperty("PROLOC")
-    private String PROLOC;
-
-    @TableField("CALCULATIONMETHOD")
-    @JsonProperty("CALCULATIONMETHOD")
-    private String CALCULATIONMETHOD;
+    @JsonProperty("NAME")
+    @TableField("NAME")
+    private String NAME;
 }

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

@@ -0,0 +1,50 @@
+package com.zksy.data.domain.po;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+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.util.Date;
+
+/**
+ * 历史法定代表人信息
+ * @TableName xcr_historical_legal_representative
+ */
+@TableName(value ="xcr_historical_legal_representative")
+@Data
+public class XcrHistoricalLegalRepresentative extends BasePo implements Serializable {
+
+    @JsonProperty("CERTYPE")
+    @TableField("CERTYPE")
+    private String CERTYPE;
+
+    @JsonProperty("CERNO")
+    @TableField("CERNO")
+    private String CERNO;
+
+    @JsonProperty("HISNAMEID")
+    @TableField("HISNAMEID")
+    @TableId
+    private String HISNAMEID;
+
+    @JsonProperty("ETPS_ID")
+    @TableField("ETPS_ID")
+    private String ETPS_ID;
+
+    @JsonProperty("PRIPID")
+    @TableField("PRIPID")
+    private String PRIPID;
+
+    @JsonProperty("S_EXT_DATATIME")
+    @TableField("S_EXT_DATATIME")
+    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date S_EXT_DATATIME;
+
+    @JsonProperty("NAME")
+    @TableField("NAME")
+    private String NAME;
+}

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

@@ -0,0 +1,39 @@
+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.util.Date;
+
+/**
+ * 历史名称信息
+ * @TableName xcr_history_name
+ */
+@TableName(value ="xcr_history_name")
+@Data
+public class XcrHistoryName extends BasePo implements Serializable {
+    @JsonProperty("HISENTNAMEID")
+    @TableField("HISENTNAMEID")
+    private String HISENTNAMEID;
+
+    @JsonProperty("ENTNAME")
+    @TableField("ENTNAME")
+    private String ENTNAME;
+
+    @JsonProperty("ETPS_ID")
+    @TableField("ETPS_ID")
+    private String ETPS_ID;
+
+    @JsonProperty("PRIPID")
+    @TableField("PRIPID")
+    private String PRIPID;
+
+    @JsonProperty("S_EXT_DATATIME")
+    @TableField("S_EXT_DATATIME")
+    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date S_EXT_DATATIME;
+}

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

@@ -0,0 +1,73 @@
+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_installment_payment
+ */
+@TableName(value ="xcr_installment_payment")
+@Data
+public class XcrInstallmentPayment extends BasePo implements Serializable {
+    @JsonProperty("CURRENCY")
+    @TableField("CURRENCY")
+    private String CURRENCY;
+
+    @JsonProperty("INVID")
+    @TableField("INVID")
+    private String INVID;
+
+    @JsonProperty("PAID")
+    @TableField("PAID")
+    private String PAID;
+
+    @JsonProperty("CONDATE")
+    @TableField("CONDATE")
+    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date CONDATE;
+
+    @JsonProperty("VERCAPORG")
+    @TableField("VERCAPORG")
+    private String VERCAPORG;
+
+    @JsonProperty("ACCONAM")
+    @TableField("ACCONAM")
+    private BigDecimal ACCONAM;
+
+    @JsonProperty("CONSOURCE")
+    @TableField("CONSOURCE")
+    private String CONSOURCE;
+
+    @JsonProperty("POSDUEREA")
+    @TableField("POSDUEREA")
+    private String POSDUEREA;
+
+    @JsonProperty("CURACTCONAMUSD")
+    @TableField("CURACTCONAMUSD")
+    private BigDecimal CURACTCONAMUSD;
+
+    @JsonProperty("CONFORM_CN")
+    @TableField("CONFORM_CN")
+    private String CONFORM_CN;
+
+    @JsonProperty("CONFORM")
+    @TableField("CONFORM")
+    private String CONFORM;
+
+    @JsonProperty("ETPS_ID")
+    @TableField("ETPS_ID")
+    private String ETPS_ID;
+
+    @JsonProperty("S_EXT_DATATIME")
+    @TableField("S_EXT_DATATIME")
+    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date S_EXT_DATATIME;
+}

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

@@ -0,0 +1,57 @@
+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_investor_subscription_details
+ */
+@TableName(value ="xcr_investor_subscription_details")
+@Data
+public class XcrInvestorSubscriptionDetails extends BasePo implements Serializable {
+    @JsonProperty("CURRENCY")
+    @TableField("CURRENCY")
+    private String CURRENCY;
+
+    @JsonProperty("SUBID")
+    @TableField("SUBID")
+    private String SUBID;
+
+    @JsonProperty("INVID")
+    @TableField("INVID")
+    private String INVID;
+
+    @JsonProperty("SUBCONAM")
+    @TableField("SUBCONAM")
+    private BigDecimal SUBCONAM;
+
+    @JsonProperty("CONFORM_CN")
+    @TableField("CONFORM_CN")
+    private String CONFORM_CN;
+
+    @JsonProperty("CONFORM")
+    @TableField("CONFORM")
+    private String CONFORM;
+
+    @JsonProperty("ETPS_ID")
+    @TableField("ETPS_ID")
+    private String ETPS_ID;
+
+    @JsonProperty("CONDATE")
+    @TableField("CONDATE")
+    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date CONDATE;
+
+    @JsonProperty("S_EXT_DATATIME")
+    @TableField("S_EXT_DATATIME")
+    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date S_EXT_DATATIME;
+}

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

@@ -0,0 +1,146 @@
+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_natural_person_contributions
+ */
+@TableName(value ="xcr_natural_person_contributions")
+@Data
+public class XcrNaturalPersonContributions extends BasePo implements Serializable {
+    @JsonProperty("ETPS_ID")
+    @TableField("ETPS_ID")
+    private String ETPS_ID;
+
+    @JsonProperty("INVID")
+    @TableField("INVID")
+    private String INVID;
+
+    @JsonProperty("SEX")
+    @TableField("SEX")
+    private String SEX;
+
+    @JsonProperty("RESPFORM")
+    @TableField("RESPFORM")
+    private String RESPFORM;
+
+    @JsonProperty("SCONFORM")
+    @TableField("SCONFORM")
+    private String SCONFORM;
+
+    @JsonProperty("INV")
+    @TableField("INV")
+    private String INV;
+
+    @JsonProperty("COUNTRY_CN")
+    @TableField("COUNTRY_CN")
+    private String COUNTRY_CN;
+
+    @JsonProperty("LISUBCONAM")
+    @TableField("LISUBCONAM")
+    private BigDecimal LISUBCONAM;
+
+    @JsonProperty("SUBCONAMUSD")
+    @TableField("SUBCONAMUSD")
+    private BigDecimal SUBCONAMUSD;
+
+    @JsonProperty("CURRENCY_CN")
+    @TableField("CURRENCY_CN")
+    private String CURRENCY_CN;
+
+    @JsonProperty("NATION")
+    @TableField("NATION")
+    private String NATION;
+
+    @JsonProperty("LITDEG")
+    @TableField("LITDEG")
+    private String LITDEG;
+
+    @JsonProperty("SUBCONFORM")
+    @TableField("SUBCONFORM")
+    private String SUBCONFORM;
+
+    @JsonProperty("COUNTRY")
+    @TableField("COUNTRY")
+    private String COUNTRY;
+
+    @JsonProperty("CERTYPE_CN")
+    @TableField("CERTYPE_CN")
+    private String CERTYPE_CN;
+
+    @JsonProperty("CURRENCY")
+    @TableField("CURRENCY")
+    private String CURRENCY;
+
+    @JsonProperty("EXEAFFSIGN")
+    @TableField("EXEAFFSIGN")
+    private String EXEAFFSIGN;
+
+    @JsonProperty("POSTALCODE")
+    @TableField("POSTALCODE")
+    private String POSTALCODE;
+
+    @JsonProperty("CERNO")
+    @TableField("CERNO")
+    private String CERNO;
+
+    @JsonProperty("DOM")
+    @TableField("DOM")
+    private String DOM;
+
+    @JsonProperty("ACCONAMUSD")
+    @TableField("ACCONAMUSD")
+    private BigDecimal ACCONAMUSD;
+
+    @JsonProperty("OCCST")
+    @TableField("OCCST")
+    private String OCCST;
+
+    @JsonProperty("LIACCONAM")
+    @TableField("LiAcConAm")
+    private BigDecimal LiAcConAm;
+
+    @JsonProperty("CONDATE")
+    @TableField("CONDATE")
+    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date CONDATE;
+
+    @JsonProperty("PRIPID")
+    @TableField("PRIPID")
+    private String PRIPID;
+
+    @JsonProperty("SUBCONPROP")
+    @TableField("SUBCONPROP")
+    private BigDecimal SUBCONPROP;
+
+    @JsonProperty("RESPFORM_CN")
+    @TableField("RESPFORM_CN")
+    private String RESPFORM_CN;
+
+    @JsonProperty("POLSTAND")
+    @TableField("POLSTAND")
+    private String POLSTAND;
+
+    @JsonProperty("TEL")
+    @TableField("TEL")
+    private String TEL;
+
+    @JsonProperty("S_EXT_DATATIME")
+    @TableField("S_EXT_DATATIME")
+    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date S_EXT_DATATIME;
+
+    @JsonProperty("NATDATE")
+    @TableField("NATDATE")
+    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date NATDATE;
+}

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

@@ -0,0 +1,121 @@
+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_non_natural_person_contribution
+ */
+@TableName(value ="xcr_non_natural_person_contribution")
+@Data
+public class XcrNonNaturalPersonContribution extends BasePo implements Serializable {
+    @JsonProperty("SUBCONAMUSD")
+    @TableField("SUBCONAMUSD")
+    private BigDecimal SUBCONAMUSD;
+
+    @JsonProperty("BLICTYPE_CN")
+    @TableField("BLICTYPE_CN")
+    private String BLICTYPE_CN;
+
+    @JsonProperty("INVID")
+    @TableField("INVID")
+    private String INVID;
+
+    @JsonProperty("SUBCONAM")
+    @TableField("SUBCONAM")
+    private BigDecimal SUBCONAM;
+
+    @JsonProperty("RESPFORM")
+    @TableField("RESPFORM")
+    private String RESPFORM;
+
+    @JsonProperty("BLICTYPE")
+    @TableField("BLICTYPE")
+    private String BLICTYPE;
+
+    @JsonProperty("INV")
+    @TableField("INV")
+    private String INV;
+
+    @JsonProperty("COUNTRY_CN")
+    @TableField("COUNTRY_CN")
+    private String COUNTRY_CN;
+
+    @JsonProperty("CURRENCY_CN")
+    @TableField("CURRENCY_CN")
+    private String CURRENCY_CN;
+
+    @JsonProperty("BLICNO")
+    @TableField("BLICNO")
+    private String BLICNO;
+
+    @JsonProperty("SUBCONFORM")
+    @TableField("SUBCONFORM")
+    private String SUBCONFORM;
+
+    @JsonProperty("COUNTRY")
+    @TableField("COUNTRY")
+    private String COUNTRY;
+
+    @JsonProperty("CURRENCY")
+    @TableField("CURRENCY")
+    private String CURRENCY;
+
+    @JsonProperty("EXEAFFSIGN")
+    @TableField("EXEAFFSIGN")
+    private String EXEAFFSIGN;
+
+    @JsonProperty("DOM")
+    @TableField("DOM")
+    private String DOM;
+
+    @JsonProperty("ACCONAMUSD")
+    @TableField("ACCONAMUSD")
+    private BigDecimal ACCONAMUSD;
+
+    @JsonProperty("CONDATE")
+    @TableField("CONDATE")
+    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date CONDATE;
+
+    @JsonProperty("PRIPID")
+    @TableField("PRIPID")
+    private String PRIPID;
+
+    @JsonProperty("INVTYPE")
+    @TableField("INVTYPE")
+    private String INVTYPE;
+
+    @JsonProperty("SUBCONPROP")
+    @TableField("SUBCONPROP")
+    private BigDecimal SUBCONPROP;
+
+    @JsonProperty("ACCONAM")
+    @TableField("ACCONAM")
+    private BigDecimal ACCONAM;
+
+    @JsonProperty("RESPFORM_CN")
+    @TableField("RESPFORM_CN")
+    private String RESPFORM_CN;
+
+    @JsonProperty("ETPS_ID")
+    @TableField("ETPS_ID")
+    private String ETPS_ID;
+
+    @JsonProperty("INVTYPE_CN")
+    @TableField("INVTYPE_CN")
+    private String INVTYPE_CN;
+
+    @JsonProperty("S_EXT_DATATIME")
+    @TableField("S_EXT_DATATIME")
+    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date S_EXT_DATATIME;
+}

data-service/src/main/java/com/zksy/data/domain/response/XcrHistoricalLegalRepresentativeResponse.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.XcrHistoricalLegalRepresentative;
+
+import java.util.List;
+
+public class XcrHistoricalLegalRepresentativeResponse extends BaseResponse {
+    @JsonProperty("data")
+    private List<XcrHistoricalLegalRepresentative> data;
+}

data-service/src/main/java/com/zksy/data/domain/response/XcrHistoryNameResponse.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.XcrHistoryName;
+
+import java.util.List;
+
+public class XcrHistoryNameResponse extends BaseResponse {
+    @JsonProperty("data")
+    private List<XcrHistoryName> data;
+}

data-service/src/main/java/com/zksy/data/domain/response/XcrInstallmentPaymentResponse.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.XcrInstallmentPayment;
+
+import java.util.List;
+
+public class XcrInstallmentPaymentResponse extends BaseResponse {
+    @JsonProperty("data")
+    private List<XcrInstallmentPayment> data;
+}

data-service/src/main/java/com/zksy/data/domain/response/XcrInvestorSubscriptionDetailsResponse.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.XcrInvestorSubscriptionDetails;
+
+import java.util.List;
+
+public class XcrInvestorSubscriptionDetailsResponse extends BaseResponse {
+    @JsonProperty("data")
+    private List<XcrInvestorSubscriptionDetails> data;
+}

data-service/src/main/java/com/zksy/data/domain/response/XcrNaturalPersonContributionsResponse.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.XcrNaturalPersonContributions;
+
+import java.util.List;
+
+public class XcrNaturalPersonContributionsResponse extends BaseResponse {
+    @JsonProperty("data")
+    private List<XcrNaturalPersonContributions> data;
+}

data-service/src/main/java/com/zksy/data/domain/response/XcrNonNaturalPersonContributionResponse.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.XcrNonNaturalPersonContribution;
+
+import java.util.List;
+
+public class XcrNonNaturalPersonContributionResponse extends BaseResponse {
+    @JsonProperty("data")
+    private List<XcrNonNaturalPersonContribution> data;
+}

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

@@ -0,0 +1,18 @@
+package com.zksy.data.mapper;
+
+import com.zksy.data.domain.po.XcrHistoricalLegalRepresentative;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author Administrator
+* @description 针对表【xcr_historical_legal_representative(历史法定代表人信息)】的数据库操作Mapper
+* @createDate 2024-10-11 10:07:22
+* @Entity com.zksy.data.domain.po.XcrHistoricalLegalRepresentative
+*/
+public interface XcrHistoricalLegalRepresentativeMapper extends BaseMapper<XcrHistoricalLegalRepresentative> {
+
+}
+
+
+
+

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

@@ -0,0 +1,18 @@
+package com.zksy.data.mapper;
+
+import com.zksy.data.domain.po.XcrHistoryName;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author Administrator
+* @description 针对表【xcr_history_name(历史名称信息)】的数据库操作Mapper
+* @createDate 2024-10-10 18:57:46
+* @Entity com.zksy.data.domain.po.XcrHistoryName
+*/
+public interface XcrHistoryNameMapper extends BaseMapper<XcrHistoryName> {
+
+}
+
+
+
+

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

@@ -0,0 +1,18 @@
+package com.zksy.data.mapper;
+
+import com.zksy.data.domain.po.XcrInstallmentPayment;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author Administrator
+* @description 针对表【xcr_installment_payment(分期实缴信息)】的数据库操作Mapper
+* @createDate 2024-10-10 16:26:24
+* @Entity com.zksy.data.domain.po.XcrInstallmentPayment
+*/
+public interface XcrInstallmentPaymentMapper extends BaseMapper<XcrInstallmentPayment> {
+
+}
+
+
+
+

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

@@ -0,0 +1,18 @@
+package com.zksy.data.mapper;
+
+import com.zksy.data.domain.po.XcrInvestorSubscriptionDetails;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author Administrator
+* @description 针对表【xcr_investor_subscription_details(投资人认缴详细)】的数据库操作Mapper
+* @createDate 2024-10-10 17:08:18
+* @Entity com.zksy.data.domain.po.XcrInvestorSubscriptionDetails
+*/
+public interface XcrInvestorSubscriptionDetailsMapper extends BaseMapper<XcrInvestorSubscriptionDetails> {
+
+}
+
+
+
+

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

@@ -0,0 +1,18 @@
+package com.zksy.data.mapper;
+
+import com.zksy.data.domain.po.XcrNaturalPersonContributions;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author Administrator
+* @description 针对表【xcr_natural_person_contributions(自然人出资信息)】的数据库操作Mapper
+* @createDate 2024-10-10 18:24:26
+* @Entity com.zksy.data.domain.po.XcrNaturalPersonContributions
+*/
+public interface XcrNaturalPersonContributionsMapper extends BaseMapper<XcrNaturalPersonContributions> {
+
+}
+
+
+
+

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

@@ -0,0 +1,18 @@
+package com.zksy.data.mapper;
+
+import com.zksy.data.domain.po.XcrNonNaturalPersonContribution;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author Administrator
+* @description 针对表【xcr_non_natural_person_contribution(非自然人出资信息)】的数据库操作Mapper
+* @createDate 2024-10-10 18:01:12
+* @Entity com.zksy.data.domain.po.XcrNonNaturalPersonContribution
+*/
+public interface XcrNonNaturalPersonContributionMapper extends BaseMapper<XcrNonNaturalPersonContribution> {
+
+}
+
+
+
+

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

@@ -0,0 +1,13 @@
+package com.zksy.data.service;
+
+import com.zksy.data.domain.po.XcrHistoricalLegalRepresentative;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author Administrator
+* @description 针对表【xcr_historical_legal_representative(历史法定代表人信息)】的数据库操作Service
+* @createDate 2024-10-11 10:07:22
+*/
+public interface XcrHistoricalLegalRepresentativeService extends IService<XcrHistoricalLegalRepresentative>,IBaseSaveDataInterface {
+
+}

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

@@ -0,0 +1,13 @@
+package com.zksy.data.service;
+
+import com.zksy.data.domain.po.XcrHistoryName;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author Administrator
+* @description 针对表【xcr_history_name(历史名称信息)】的数据库操作Service
+* @createDate 2024-10-10 18:57:46
+*/
+public interface XcrHistoryNameService extends IService<XcrHistoryName>, IBaseSaveDataInterface {
+
+}

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

@@ -0,0 +1,13 @@
+package com.zksy.data.service;
+
+import com.zksy.data.domain.po.XcrInstallmentPayment;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author Administrator
+* @description 针对表【xcr_installment_payment(分期实缴信息)】的数据库操作Service
+* @createDate 2024-10-10 16:26:24
+*/
+public interface XcrInstallmentPaymentService extends IService<XcrInstallmentPayment>,IBaseSaveDataInterface {
+
+}

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

@@ -0,0 +1,13 @@
+package com.zksy.data.service;
+
+import com.zksy.data.domain.po.XcrInvestorSubscriptionDetails;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author Administrator
+* @description 针对表【xcr_investor_subscription_details(投资人认缴详细)】的数据库操作Service
+* @createDate 2024-10-10 17:08:18
+*/
+public interface XcrInvestorSubscriptionDetailsService extends IService<XcrInvestorSubscriptionDetails>,IBaseSaveDataInterface {
+
+}

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

@@ -0,0 +1,13 @@
+package com.zksy.data.service;
+
+import com.zksy.data.domain.po.XcrNaturalPersonContributions;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author Administrator
+* @description 针对表【xcr_natural_person_contributions(自然人出资信息)】的数据库操作Service
+* @createDate 2024-10-10 18:24:26
+*/
+public interface XcrNaturalPersonContributionsService extends IService<XcrNaturalPersonContributions>,IBaseSaveDataInterface {
+
+}

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

@@ -0,0 +1,13 @@
+package com.zksy.data.service;
+
+import com.zksy.data.domain.po.XcrNonNaturalPersonContribution;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author Administrator
+* @description 针对表【xcr_non_natural_person_contribution(非自然人出资信息)】的数据库操作Service
+* @createDate 2024-10-10 18:01:12
+*/
+public interface XcrNonNaturalPersonContributionService extends IService<XcrNonNaturalPersonContribution>,IBaseSaveDataInterface {
+
+}

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

@@ -30,7 +30,7 @@ public class XcrAgriculturalSupplementServiceImpl extends ServiceImpl<XcrAgricul
     private RedisService redisService;
 
     @Override
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public void saveDataByUniCode(String address) {
         //模拟从数据库中取数据大约为3000-4000条
         List<String> creditCodes = (List<String>) redisService.getList("creditCodes").get(0);

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

@@ -30,7 +30,7 @@ public class XcrAppointDelegatesServiceImpl extends ServiceImpl<XcrAppointDelega
     private RedisService redisService;
 
     @Override
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public void saveDataByUniCode(String address) {
         //模拟从数据库中取数据大约为3000-4000条
         List<String> creditCodes = (List<String>) redisService.getList("creditCodes").get(0);

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

@@ -30,7 +30,7 @@ public class XcrCompanyInvestmentServiceImpl extends ServiceImpl<XcrCompanyInves
     private RedisService redisService;
 
     @Override
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public void saveDataByUniCode(String address) {
         //模拟从数据库中取数据大约为3000-4000条
         List<String> creditCodes = (List<String>) redisService.getList("creditCodes").get(0);

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

@@ -30,7 +30,7 @@ public class XcrDomesticCapitalSupplementServiceImpl extends ServiceImpl<XcrDome
     private RedisService redisService;
 
     @Override
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public void saveDataByUniCode(String address) {
         //模拟从数据库中取数据大约为3000-4000条
         List<String> creditCodes = (List<String>) redisService.getList("creditCodes").get(0);

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

@@ -28,11 +28,9 @@ public class XcrELicNcertificateServiceImpl extends ServiceImpl<XcrELicNcertific
     @Autowired
     private XhRequestUtil xhRequestUtil;
     @Autowired
-    private XcrELicNcertificateMapper xcrELicNcertificateMapper;
-    @Autowired
     private RedisService redisService;
     @Override
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public void saveDataByUniCode(String address) {
         //模拟从数据库中取数据大约为3000-4000条
         List<String> creditCodes = (List<String>) redisService.getList("creditCodes").get(0);

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

@@ -29,11 +29,9 @@ public class XcrEquityChangeServiceImpl extends ServiceImpl<XcrEquityChangeMappe
     private XhRequestUtil xhRequestUtil;
     @Autowired
     private RedisService redisService;
-    @Autowired
-    private XcrEquityChangeMapper xcrEquityChangeMapper;
 
     @Override
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public void saveDataByUniCode(String address) {
         //模拟从数据库中取数据大约为3000-4000条
         List<String> creditCodes = (List<String>) redisService.getList("creditCodes").get(0);

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

@@ -0,0 +1,55 @@
+package com.zksy.data.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.zksy.data.domain.po.XcrHistoricalLegalRepresentative;
+import com.zksy.data.domain.response.XcrHistoricalLegalRepresentativeResponse;
+import com.zksy.data.mapper.XcrHistoricalLegalRepresentativeMapper;
+import com.zksy.data.service.XcrHistoricalLegalRepresentativeService;
+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_historical_legal_representative(历史法定代表人信息)】的数据库操作Service实现
+* @createDate 2024-10-11 10:07:22
+*/
+@Service
+@Slf4j
+public class XcrHistoricalLegalRepresentativeServiceImpl extends ServiceImpl<XcrHistoricalLegalRepresentativeMapper, XcrHistoricalLegalRepresentative>
+    implements XcrHistoricalLegalRepresentativeService{
+    @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<XcrHistoricalLegalRepresentative> toDatabaseList = new Vector<>();
+        creditCodes.parallelStream().forEach(creditCode -> {
+            List<XcrHistoricalLegalRepresentative> list = xhRequestUtil.httpRequestByUniCode(creditCode, address,
+                    XcrHistoricalLegalRepresentativeResponse.class,
+                    XcrHistoricalLegalRepresentative.class
+            );
+            if(list != null){
+                toDatabaseList.addAll(list);
+            }
+        });
+        this.remove(null);
+        this.saveBatch(toDatabaseList);
+        log.info("历史法定代表人信息同步完成");
+    }
+}
+
+
+
+

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

@@ -0,0 +1,55 @@
+package com.zksy.data.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.zksy.data.domain.po.XcrHistoryName;
+import com.zksy.data.domain.response.XcrHistoryNameResponse;
+import com.zksy.data.mapper.XcrHistoryNameMapper;
+import com.zksy.data.service.XcrHistoryNameService;
+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_history_name(历史名称信息)】的数据库操作Service实现
+* @createDate 2024-10-10 18:57:46
+*/
+@Service
+@Slf4j
+public class XcrHistoryNameServiceImpl extends ServiceImpl<XcrHistoryNameMapper, XcrHistoryName>
+    implements XcrHistoryNameService{
+    @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<XcrHistoryName> toDatabaseList = new Vector<>();
+        creditCodes.parallelStream().forEach(creditCode -> {
+            List<XcrHistoryName> list = xhRequestUtil.httpRequestByUniCode(creditCode, address,
+                    XcrHistoryNameResponse.class,
+                    XcrHistoryName.class
+            );
+            if(list != null){
+                toDatabaseList.addAll(list);
+            }
+        });
+        this.remove(null);
+        this.saveBatch(toDatabaseList);
+        log.info("历史名称信息同步完成");
+    }
+}
+
+
+
+

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

@@ -0,0 +1,55 @@
+package com.zksy.data.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.zksy.data.domain.po.XcrInstallmentPayment;
+import com.zksy.data.domain.response.XcrInstallmentPaymentResponse;
+import com.zksy.data.mapper.XcrInstallmentPaymentMapper;
+import com.zksy.data.service.XcrInstallmentPaymentService;
+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_installment_payment(分期实缴信息)】的数据库操作Service实现
+* @createDate 2024-10-10 16:26:24
+*/
+@Service
+@Slf4j
+public class XcrInstallmentPaymentServiceImpl extends ServiceImpl<XcrInstallmentPaymentMapper, XcrInstallmentPayment>
+    implements XcrInstallmentPaymentService{
+    @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<XcrInstallmentPayment> toDatabaseList = new Vector<>();
+        creditCodes.parallelStream().forEach(creditCode -> {
+            List<XcrInstallmentPayment> list = xhRequestUtil.httpRequestByUniCode(creditCode, address,
+                    XcrInstallmentPaymentResponse.class,
+                    XcrInstallmentPayment.class
+            );
+            if(list != null){
+                toDatabaseList.addAll(list);
+            }
+        });
+        this.remove(null);
+        this.saveBatch(toDatabaseList);
+        log.info("分期实缴信息同步完成");
+    }
+}
+
+
+
+

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

@@ -0,0 +1,55 @@
+package com.zksy.data.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.zksy.data.domain.po.XcrInvestorSubscriptionDetails;
+import com.zksy.data.domain.response.XcrInvestorSubscriptionDetailsResponse;
+import com.zksy.data.mapper.XcrInvestorSubscriptionDetailsMapper;
+import com.zksy.data.service.XcrInvestorSubscriptionDetailsService;
+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_investor_subscription_details(投资人认缴详细)】的数据库操作Service实现
+* @createDate 2024-10-10 17:08:18
+*/
+@Service
+@Slf4j
+public class XcrInvestorSubscriptionDetailsServiceImpl extends ServiceImpl<XcrInvestorSubscriptionDetailsMapper, XcrInvestorSubscriptionDetails>
+    implements XcrInvestorSubscriptionDetailsService{
+    @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<XcrInvestorSubscriptionDetails> toDatabaseList = new Vector<>();
+        creditCodes.parallelStream().forEach(creditCode -> {
+            List<XcrInvestorSubscriptionDetails> list = xhRequestUtil.httpRequestByUniCode(creditCode, address,
+                    XcrInvestorSubscriptionDetailsResponse.class,
+                    XcrInvestorSubscriptionDetails.class
+            );
+            if(list != null){
+                toDatabaseList.addAll(list);
+            }
+        });
+        this.remove(null);
+        this.saveBatch(toDatabaseList);
+        log.info("投资人认缴详细同步完成");
+    }
+}
+
+
+
+

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

@@ -0,0 +1,55 @@
+package com.zksy.data.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.zksy.data.domain.po.XcrNaturalPersonContributions;
+import com.zksy.data.domain.response.XcrNaturalPersonContributionsResponse;
+import com.zksy.data.mapper.XcrNaturalPersonContributionsMapper;
+import com.zksy.data.service.XcrNaturalPersonContributionsService;
+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_natural_person_contributions(自然人出资信息)】的数据库操作Service实现
+* @createDate 2024-10-10 18:24:26
+*/
+@Service
+@Slf4j
+public class XcrNaturalPersonContributionsServiceImpl extends ServiceImpl<XcrNaturalPersonContributionsMapper, XcrNaturalPersonContributions>
+    implements XcrNaturalPersonContributionsService{
+    @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<XcrNaturalPersonContributions> toDatabaseList = new Vector<>();
+        creditCodes.parallelStream().forEach(creditCode -> {
+            List<XcrNaturalPersonContributions> list = xhRequestUtil.httpRequestByUniCode(creditCode, address,
+                    XcrNaturalPersonContributionsResponse.class,
+                    XcrNaturalPersonContributions.class
+            );
+            if(list != null){
+                toDatabaseList.addAll(list);
+            }
+        });
+        this.remove(null);
+        this.saveBatch(toDatabaseList);
+        log.info("自然人出资信息同步完成");
+    }
+}
+
+
+
+

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

@@ -0,0 +1,55 @@
+package com.zksy.data.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.zksy.data.domain.po.XcrNonNaturalPersonContribution;
+import com.zksy.data.domain.response.XcrNonNaturalPersonContributionResponse;
+import com.zksy.data.mapper.XcrNonNaturalPersonContributionMapper;
+import com.zksy.data.service.XcrNonNaturalPersonContributionService;
+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_non_natural_person_contribution(非自然人出资信息)】的数据库操作Service实现
+* @createDate 2024-10-10 18:01:12
+*/
+@Service
+@Slf4j
+public class XcrNonNaturalPersonContributionServiceImpl extends ServiceImpl<XcrNonNaturalPersonContributionMapper, XcrNonNaturalPersonContribution>
+    implements XcrNonNaturalPersonContributionService{
+    @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<XcrNonNaturalPersonContribution> toDatabaseList = new Vector<>();
+        creditCodes.parallelStream().forEach(creditCode -> {
+            List<XcrNonNaturalPersonContribution> list = xhRequestUtil.httpRequestByUniCode(creditCode, address,
+                    XcrNonNaturalPersonContributionResponse.class,
+                    XcrNonNaturalPersonContribution.class
+            );
+            if(list != null){
+                toDatabaseList.addAll(list);
+            }
+        });
+        this.remove(null);
+        this.saveBatch(toDatabaseList);
+        log.info("非自然人出资信息同步完成");
+    }
+}
+
+
+
+

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

@@ -31,7 +31,7 @@ public class XcrSupplementaryForeignInvestmentServiceImpl extends ServiceImpl<Xc
     private RedisService redisService;
 
     @Override
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public void saveDataByUniCode(String address) {
         //模拟从数据库中取数据大约为3000-4000条
         List<String> creditCodes = (List<String>) redisService.getList("creditCodes").get(0);

data-service/src/main/java/com/zksy/data/utils/XhRequestUtil.java

@@ -4,19 +4,21 @@ import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.core.util.StrUtil;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.zksy.common.domain.response.BaseResponse;
+import com.zksy.common.exception.CommonException;
 import com.zksy.common.utils.BeanUtils;
 import com.zksy.data.config.XhConfigProperty;
+import com.zksy.data.constant.RedisKeyConstant;
 import com.zksy.data.domain.po.BasePo;
 import lombok.extern.slf4j.Slf4j;
-import okhttp3.HttpUrl;
-import okhttp3.OkHttpClient;
-import okhttp3.Request;
-import okhttp3.Response;
+import okhttp3.*;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Component;
 
 import java.util.ArrayList;
+import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
 
 @Component
 @Slf4j
@@ -27,10 +29,13 @@ public class XhRequestUtil {
     private OkHttpClient okHttpClient;
     @Autowired
     private ObjectMapper objectMapper;
+    @Autowired
+    private RedisTemplate<String,String> redisTemplate;
 
     public <T extends BaseResponse,K extends BasePo> List<K> httpRequestByUniCode(String uniCode, String address,
                                                                                Class<T> responseClass,
                                                                                Class<K> entityClass) {
+        log.info("正在同步:{}下的:{}",address,uniCode);
         ArrayList<K> resList = new ArrayList<>();
         if (StrUtil.isEmpty(uniCode)) {
             log.warn("统一社会信用代码为空");
@@ -76,7 +81,7 @@ public class XhRequestUtil {
         }
     }
     private Boolean isEnd = false;
-    public String testHttpRequest(String uniCode,String address) {
+    public String testHttpRequest(String uniCode,String address,String paramsValue) {
         if (isEnd) {
             isEnd = false;
             throw new RuntimeException("已经找到请求结构,不用继续了");
@@ -90,7 +95,7 @@ public class XhRequestUtil {
                 .host(xhConfigProperty.getHost())
                 .port(Integer.valueOf(xhConfigProperty.getPort()))
                 .addPathSegment(address)
-                .addQueryParameter("UNISCID", uniCode)
+                .addQueryParameter(paramsValue, uniCode)
                 .build();
         Request request = new Request.Builder()
                 .url(url)
@@ -117,4 +122,77 @@ public class XhRequestUtil {
         }
         return null;
     }
+
+    public void requestXinyonghuanhuai(){
+        refreshToken();
+        HttpUrl url = new HttpUrl.Builder()
+                .scheme("http")
+                .host("59.231.127.12")
+                .addPathSegment("interface/v1/doublePublic/findLicensingList")
+                .build();
+        Map<String, Object> requestBodyMap = new HashMap<>();
+        requestBodyMap.put("entityCode", "91431227MA4QPUTX06");
+//        requestBodyMap.put("entityName", "滴滴");
+//        requestBodyMap.put("entityCodeAdd", "12345");
+//        requestBodyMap.put("wsh", "");
+//        requestBodyMap.put("upDateBegin", "2023-01-01 00:00:00");
+//        requestBodyMap.put("upDateEnd", "2023-12-01 00:00:00");
+//        requestBodyMap.put("size", 10);
+//        requestBodyMap.put("page", 1);
+        try {
+            var json = objectMapper.writeValueAsString(requestBodyMap);
+            RequestBody requestBody = RequestBody.create(json, MediaType.parse("application/json; charset=utf-8"));
+            Request request = new Request.Builder()
+                    .url(url)
+                    .header("Content-Type", "application/json")
+                    .header("Token", redisTemplate.opsForValue().get(RedisKeyConstant.HUAIHUA_TOKEN_KEY))
+                    .post(requestBody)
+                    .build();
+            Response response = okHttpClient.newCall(request).execute();
+            if (!response.isSuccessful()) {
+                throw new CommonException("当前接口请求失败",5000);
+            }
+            if (ObjectUtil.isEmpty(response.body())) {
+                throw new CommonException("当前接口请求失败",5000);
+            }
+            String s = response.body().string();
+            log.info(s);
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+    }
+
+    private void refreshToken() {
+        HttpUrl url = new HttpUrl.Builder()
+                .scheme("http")
+                .host("59.231.127.12")
+                .addPathSegment("interface/v1/auth/getToken")
+                .addQueryParameter("refreshToken", "sV7l0nLP2Ui157VRd1TvIkSpfixf22ij")
+                .build();
+        Request request = new Request.Builder()
+                .url(url)
+                .get()
+                .build();
+        try {
+            Response response = okHttpClient.newCall(request).execute();
+            if (!response.isSuccessful()) {
+                throw new CommonException("刷新token的接口请求失败",5000);
+            }
+            if (ObjectUtil.isEmpty(response.body())) {
+                throw new CommonException("刷新token的接口出现问题",5000);
+            }
+            String s = response.body().string();
+            Map map = objectMapper.readValue(s, Map.class);
+            if((Integer) map.get("status") != 0){
+                throw new CommonException("刷新token的接口返回异常",5000);
+            }
+            String token = (String) map.get("data");
+            if(StrUtil.isEmpty(token)){
+                throw new CommonException("刷新token的接口返回异常",5000);
+            }
+            redisTemplate.opsForValue().set(RedisKeyConstant.HUAIHUA_TOKEN_KEY,token);
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+    }
 }

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

@@ -0,0 +1,22 @@
+<?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.XcrHistoricalLegalRepresentativeMapper">
+
+    <resultMap id="BaseResultMap" type="com.zksy.data.domain.po.XcrHistoricalLegalRepresentative">
+            <result property="etpsId" column="ETPS_ID" jdbcType="VARCHAR"/>
+            <result property="hisnameid" column="HISNAMEID" jdbcType="VARCHAR"/>
+            <result property="pripid" column="PRIPID" jdbcType="VARCHAR"/>
+            <result property="name" column="NAME" jdbcType="VARCHAR"/>
+            <result property="certype" column="CERTYPE" jdbcType="VARCHAR"/>
+            <result property="cerno" column="CERNO" jdbcType="VARCHAR"/>
+            <result property="sExtDatatime" column="S_EXT_DATATIME" jdbcType="TIMESTAMP"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        ETPS_ID,HISNAMEID,PRIPID,
+        NAME,CERTYPE,CERNO,
+        S_EXT_DATATIME
+    </sql>
+</mapper>

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

@@ -0,0 +1,19 @@
+<?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.XcrHistoryNameMapper">
+
+    <resultMap id="BaseResultMap" type="com.zksy.data.domain.po.XcrHistoryName">
+            <result property="hisentnameid" column="HISENTNAMEID" jdbcType="VARCHAR"/>
+            <result property="etpsId" column="ETPS_ID" jdbcType="VARCHAR"/>
+            <result property="pripid" column="PRIPID" jdbcType="VARCHAR"/>
+            <result property="entname" column="ENTNAME" jdbcType="VARCHAR"/>
+            <result property="sExtDatatime" column="S_EXT_DATATIME" jdbcType="TIMESTAMP"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        HISENTNAMEID,ETPS_ID,PRIPID,
+        ENTNAME,S_EXT_DATATIME
+    </sql>
+</mapper>

data-service/src/main/resources/mapper/XcrInstallmentPaymentMapper.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.XcrInstallmentPaymentMapper">
+
+    <resultMap id="BaseResultMap" type="com.zksy.data.domain.po.XcrInstallmentPayment">
+            <id property="paid" column="PAID" jdbcType="VARCHAR"/>
+            <result property="invid" column="INVID" jdbcType="VARCHAR"/>
+            <result property="acconam" column="ACCONAM" jdbcType="DECIMAL"/>
+            <result property="conform" column="CONFORM" jdbcType="VARCHAR"/>
+            <result property="conformCn" column="CONFORM_CN" jdbcType="VARCHAR"/>
+            <result property="condate" column="CONDATE" jdbcType="DATE"/>
+            <result property="curactconamusd" column="CURACTCONAMUSD" jdbcType="DECIMAL"/>
+            <result property="currency" column="CURRENCY" jdbcType="VARCHAR"/>
+            <result property="consource" column="CONSOURCE" jdbcType="VARCHAR"/>
+            <result property="posduerea" column="POSDUEREA" jdbcType="VARCHAR"/>
+            <result property="vercaporg" column="VERCAPORG" jdbcType="VARCHAR"/>
+            <result property="sExtDatatime" column="S_EXT_DATATIME" jdbcType="TIMESTAMP"/>
+            <result property="etpsId" column="ETPS_ID" jdbcType="VARCHAR"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        PAID,INVID,ACCONAM,
+        CONFORM,CONFORM_CN,CONDATE,
+        CURACTCONAMUSD,CURRENCY,CONSOURCE,
+        POSDUEREA,VERCAPORG,S_EXT_DATATIME,
+        ETPS_ID
+    </sql>
+</mapper>

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

@@ -0,0 +1,24 @@
+<?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.XcrInvestorSubscriptionDetailsMapper">
+
+    <resultMap id="BaseResultMap" type="com.zksy.data.domain.po.XcrInvestorSubscriptionDetails">
+            <id property="subid" column="SUBID" jdbcType="VARCHAR"/>
+            <result property="invid" column="INVID" jdbcType="VARCHAR"/>
+            <result property="subconam" column="SUBCONAM" jdbcType="DECIMAL"/>
+            <result property="conform" column="CONFORM" jdbcType="VARCHAR"/>
+            <result property="conformCn" column="CONFORM_CN" jdbcType="VARCHAR"/>
+            <result property="condate" column="CONDATE" jdbcType="DATE"/>
+            <result property="currency" column="CURRENCY" jdbcType="VARCHAR"/>
+            <result property="sExtDatatime" column="S_EXT_DATATIME" jdbcType="TIMESTAMP"/>
+            <result property="etpsId" column="ETPS_ID" jdbcType="VARCHAR"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        SUBID,INVID,SUBCONAM,
+        CONFORM,CONFORM_CN,CONDATE,
+        CURRENCY,S_EXT_DATATIME,ETPS_ID
+    </sql>
+</mapper>

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

@@ -0,0 +1,56 @@
+<?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.XcrNaturalPersonContributionsMapper">
+
+    <resultMap id="BaseResultMap" type="com.zksy.data.domain.po.XcrNaturalPersonContributions">
+            <id property="invid" column="INVID" jdbcType="VARCHAR"/>
+            <result property="etpsId" column="ETPS_ID" jdbcType="VARCHAR"/>
+            <result property="pripid" column="PRIPID" jdbcType="VARCHAR"/>
+            <result property="inv" column="INV" jdbcType="VARCHAR"/>
+            <result property="certype" column="CERTYPE" jdbcType="VARCHAR"/>
+            <result property="certypeCn" column="CERTYPE_CN" jdbcType="VARCHAR"/>
+            <result property="cerno" column="CERNO" jdbcType="VARCHAR"/>
+            <result property="lisubconam" column="LISUBCONAM" jdbcType="DECIMAL"/>
+            <result property="subconamusd" column="SUBCONAMUSD" jdbcType="DECIMAL"/>
+            <result property="subconform" column="SUBCONFORM" jdbcType="VARCHAR"/>
+            <result property="subconprop" column="SUBCONPROP" jdbcType="DECIMAL"/>
+            <result property="condate" column="CONDATE" jdbcType="DATE"/>
+            <result property="liacconam" column="LiAcConAm" jdbcType="DECIMAL"/>
+            <result property="acconamusd" column="ACCONAMUSD" jdbcType="DECIMAL"/>
+            <result property="dom" column="DOM" jdbcType="VARCHAR"/>
+            <result property="currency" column="CURRENCY" jdbcType="VARCHAR"/>
+            <result property="currencyCn" column="CURRENCY_CN" jdbcType="VARCHAR"/>
+            <result property="country" column="COUNTRY" jdbcType="VARCHAR"/>
+            <result property="countryCn" column="COUNTRY_CN" jdbcType="VARCHAR"/>
+            <result property="exeaffsign" column="EXEAFFSIGN" jdbcType="VARCHAR"/>
+            <result property="respform" column="RESPFORM" jdbcType="VARCHAR"/>
+            <result property="respformCn" column="RESPFORM_CN" jdbcType="VARCHAR"/>
+            <result property="sconform" column="SCONFORM" jdbcType="VARCHAR"/>
+            <result property="sex" column="SEX" jdbcType="VARCHAR"/>
+            <result property="nation" column="NATION" jdbcType="VARCHAR"/>
+            <result property="natdate" column="NATDATE" jdbcType="DATE"/>
+            <result property="litdeg" column="LITDEG" jdbcType="VARCHAR"/>
+            <result property="polstand" column="POLSTAND" jdbcType="VARCHAR"/>
+            <result property="occst" column="OCCST" jdbcType="VARCHAR"/>
+            <result property="postalcode" column="POSTALCODE" jdbcType="VARCHAR"/>
+            <result property="tel" column="TEL" jdbcType="VARCHAR"/>
+            <result property="sExtDatatime" column="S_EXT_DATATIME" jdbcType="TIMESTAMP"/>
+            <result property="sExtTimestamp" column="S_EXT_TIMESTAMP" jdbcType="TIMESTAMP"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        INVID,ETPS_ID,PRIPID,
+        INV,CERTYPE,CERTYPE_CN,
+        CERNO,LISUBCONAM,SUBCONAMUSD,
+        SUBCONFORM,SUBCONPROP,CONDATE,
+        LiAcConAm,ACCONAMUSD,DOM,
+        CURRENCY,CURRENCY_CN,COUNTRY,
+        COUNTRY_CN,EXEAFFSIGN,RESPFORM,
+        RESPFORM_CN,SCONFORM,SEX,
+        NATION,NATDATE,LITDEG,
+        POLSTAND,OCCST,POSTALCODE,
+        TEL,S_EXT_DATATIME,S_EXT_TIMESTAMP
+    </sql>
+</mapper>

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

@@ -0,0 +1,46 @@
+<?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.XcrNonNaturalPersonContributionMapper">
+
+    <resultMap id="BaseResultMap" type="com.zksy.data.domain.po.XcrNonNaturalPersonContribution">
+            <id property="invid" column="INVID" jdbcType="VARCHAR"/>
+            <result property="etpsId" column="ETPS_ID" jdbcType="VARCHAR"/>
+            <result property="pripid" column="PRIPID" jdbcType="VARCHAR"/>
+            <result property="inv" column="INV" jdbcType="VARCHAR"/>
+            <result property="invtype" column="INVTYPE" jdbcType="VARCHAR"/>
+            <result property="invtypeCn" column="INVTYPE_CN" jdbcType="VARCHAR"/>
+            <result property="blictype" column="BLICTYPE" jdbcType="VARCHAR"/>
+            <result property="blictypeCn" column="BLICTYPE_CN" jdbcType="VARCHAR"/>
+            <result property="blicno" column="BLICNO" jdbcType="VARCHAR"/>
+            <result property="subconam" column="SUBCONAM" jdbcType="DECIMAL"/>
+            <result property="subconamusd" column="SUBCONAMUSD" jdbcType="DECIMAL"/>
+            <result property="subconform" column="SUBCONFORM" jdbcType="VARCHAR"/>
+            <result property="subconprop" column="SUBCONPROP" jdbcType="DECIMAL"/>
+            <result property="condate" column="CONDATE" jdbcType="DATE"/>
+            <result property="acconam" column="ACCONAM" jdbcType="DECIMAL"/>
+            <result property="acconamusd" column="ACCONAMUSD" jdbcType="DECIMAL"/>
+            <result property="dom" column="DOM" jdbcType="VARCHAR"/>
+            <result property="currency" column="CURRENCY" jdbcType="VARCHAR"/>
+            <result property="currencyCn" column="CURRENCY_CN" jdbcType="VARCHAR"/>
+            <result property="country" column="COUNTRY" jdbcType="VARCHAR"/>
+            <result property="countryCn" column="COUNTRY_CN" jdbcType="VARCHAR"/>
+            <result property="exeaffsign" column="EXEAFFSIGN" jdbcType="VARCHAR"/>
+            <result property="respform" column="RESPFORM" jdbcType="VARCHAR"/>
+            <result property="respformCn" column="RESPFORM_CN" jdbcType="VARCHAR"/>
+            <result property="sExtDatatime" column="S_EXT_DATATIME" jdbcType="TIMESTAMP"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        INVID,ETPS_ID,PRIPID,
+        INV,INVTYPE,INVTYPE_CN,
+        BLICTYPE,BLICTYPE_CN,BLICNO,
+        SUBCONAM,SUBCONAMUSD,SUBCONFORM,
+        SUBCONPROP,CONDATE,ACCONAM,
+        ACCONAMUSD,DOM,CURRENCY,
+        CURRENCY_CN,COUNTRY,COUNTRY_CN,
+        EXEAFFSIGN,RESPFORM,RESPFORM_CN,
+        S_EXT_DATATIME
+    </sql>
+</mapper>