注销税务登记信息数据采集

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

@@ -0,0 +1,13 @@
+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.XcrAbnormalHouseholdIdentification;
+import com.zksy.data.domain.po.XcrCancelTaxRegistration;
+
+import java.util.List;
+
+public class XcrAbnormalHouseholdIdentificationResponse extends BaseResponse {
+    @JsonProperty("data")
+    private List<XcrAbnormalHouseholdIdentification> data;
+}

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

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

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

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

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

@@ -0,0 +1,13 @@
+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.XcrAbnormalHouseholdIdentification;
+import com.zksy.data.domain.po.XcrMainFinancialStatements;
+
+import java.util.List;
+
+public class XcrMainFinancialStatementsResponse extends BaseResponse {
+    @JsonProperty("data")
+    private List<XcrMainFinancialStatements> data;
+}

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

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

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

@@ -0,0 +1,13 @@
+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.XcrAbnormalHouseholdIdentification;
+import com.zksy.data.domain.po.XcrTaxpayerCreditRating;
+
+import java.util.List;
+
+public class XcrTaxpayerCreditRatingResponse extends BaseResponse {
+    @JsonProperty("data")
+    private List<XcrTaxpayerCreditRating> data;
+}

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

@@ -0,0 +1,58 @@
+package com.zksy.data.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.zksy.data.domain.po.XcrCancelTaxRegistration;
+import com.zksy.data.domain.po.XcrTaxAdministrativePenalty;
+import com.zksy.data.domain.response.XcrCancelTaxRegistrationResponse;
+import com.zksy.data.domain.response.XcrTaxAdministrativePenaltyResponse;
+import com.zksy.data.service.XcrCancelTaxRegistrationService;
+import com.zksy.data.mapper.XcrCancelTaxRegistrationMapper;
+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 邵洋
+* @description 针对表【xcr_cancel_tax_registration(注销税务登记信息)】的数据库操作Service实现
+* @createDate 2024-10-17 09:43:25
+*/
+@Service
+@Slf4j
+public class XcrCancelTaxRegistrationServiceImpl extends ServiceImpl<XcrCancelTaxRegistrationMapper, XcrCancelTaxRegistration>
+    implements XcrCancelTaxRegistrationService{
+    @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<XcrCancelTaxRegistration> toDatabaseList = new Vector<>();
+        creditCodes.parallelStream().forEach(creditCode -> {
+            List<XcrCancelTaxRegistration> list = xhRequestUtil.httpRequestByUniCode(creditCode, address,
+                    XcrCancelTaxRegistrationResponse.class,
+                    XcrCancelTaxRegistration.class,
+                    "SHXYDM"
+            );
+            if(list != null){
+                toDatabaseList.addAll(list);
+            }
+        });
+        this.remove(null);
+        this.saveBatch(toDatabaseList);
+        log.info("注销税务登记信息同步完成");
+    }
+}
+
+
+
+