邵洋 il y a 1 an
Parent
commit
3e9877263f

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

@@ -3,6 +3,7 @@ package com.zksy.data.controller;
 import com.zksy.data.service.*;
 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.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
@@ -16,6 +17,7 @@ import java.util.Objects;
 
 @RestController
 @RequestMapping("/test")
+@Slf4j
 public class TestController {
     @Autowired
     private XhRequestUtil xhRequestUtil;
@@ -217,159 +219,175 @@ public class TestController {
     private XcrEnterprisePollutionPermitInfoService xcrEnterprisePollutionPermitInfoService;
     @Autowired
     private XcrKeyPollutionSourcesService xcrKeyPollutionSourcesService;
+    @Autowired
+    private XcrAgriculturalSpecializedWebsiteService xcrAgriculturalSpecializedWebsiteService;
+    @Autowired
+    private XcrMajorMembersService xcrMajorMembersService;
     @GetMapping("/a")
     public String hello(){
-        xcrELicNcertificateService.saveDataByUniCode("gateway/api/1/getXzxkxxByUniscid");
-        xcrCompanyInvestmentService.saveDataByUniCode("gateway/api/1/getGdjczxgxxByUniscid");
-        xcrEquityChangeService.saveDataByUniCode("gateway/api/1/getGqczbgxxByUniscid");
-        xcrSupplementaryForeignInvestmentService.saveDataByUniCode("gateway/api/1/getWzbcxxByUniscid");
-        xcrAppointDelegatesService.saveDataByUniCode("gateway/api/1/getWpdbxxByUniscid");
-        xcrAgriculturalSupplementService.saveDataByUniCode("gateway/api/1/getNzbcxxByUniscid");
-        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");
-        //非正常户解除信息
-//        xcrAbnormalHouseholdTerminationService.saveDataByUniCode("gateway/api/1/getFzchjcxxByUniscid");
-        xcrTaxAdministrativePenaltyService.saveDataByUniCode("gateway/api/1/getSwxzcfxxByUniscid");
-        xcrAffiliatedEnterpriseService.saveDataByUniCode("gateway/api/1/getLsqyxxByUniscid");
-        xcrInstallmentSubscriptionService.saveDataByUniCode("gateway/api/1/getFqrjxxByUniscid");
-        xcrAdministrativeLicensingAgriculturalCollegesService.saveDataByUniCode("gateway/api/1/getNznbxzxkxxByUniscid");
-        xcrEnterpriseExceptionListService.saveDataByUniCode("gateway/api/1/getQyycmlxxByUniscid1");
-        xcrInvestorAbnormalRecordService.saveDataByUniCode("gateway/api/1/getQyjyycmlgdxxByUnsicd");
-        xcrEnterprisePublicityLicenseService.saveDataByUniCode("gateway/api/1/getQygsxkxxByUniscid");
-        xcrEnterprisePublicityEquityChangeService.saveDataByUniCode("gateway/api/1/getQygsgqbgxxByUniscid");
-        xcrSimplifiedCancellationAnnouncementService.saveDataByUniCode("gateway/api/1/getJyzxggxxByUniscid");
-        xcrCancelTaxRegistrationService.saveDataByUniCode("gateway/api/1/getZxswdjxxByUniscid");
-        xcrEnterprisePublicityInvestorInformationStatusService.saveDataByUniCode("gateway/api/1/getQygsczrxxqkByUniscid");
-        xcrEnterprisePublicityDetailsContributionsContributorsService.saveDataByUniCode("gateway/api/1/getCzrsjmxByUniscid");
-        xcrEnterprisePublicationSupplySubscribedDetailsInvestorsService.saveDataByUniCode("gateway/api/1/getQygsczrrjmxByUniscid");
-        xcrRevisionInformationAgriculturalCollegeAnnualReportService.saveDataByUniCode("gateway/api/1/getNznbxgxxByUniscid");
-        xcrBasicSupplementAgriculturalCollegeAnnualService.saveDataByUniCode("gateway/api/1/getNznbjbxxbcByUniscid");
-        xcrEnterpriseBasicInformationService.saveDataByUniCode("gateway/api/1/getQyjbxxByUniscid");
-        xcrEnterpriseNameApprovalService.saveDataByUniCode("gateway/api/1/getQymcxxByUniscid");
-        xcrSeriousIllegalDishonestEnterprisesService.saveDataByUniCode("gateway/api/1/getYzwfsxqymdBydm");
-        xcrSeriousIllegalDishonestEnterprisesDetailService.saveDataByUniCode("gateway/api/1/getYzwfxxxxByUniscid");
-        xcrEquityPledgeInfoService.saveDataByUniCode("gateway/api/1/getGqczdjxxBydm");
-        xcrEquityFreezeService.saveDataByUniCode("gateway/api/1/getGqdjxxByUniscid");
-        xcrEquityChangeInfoService.saveDataByUniCode("gateway/api/1/getGqbgxxByUniscid");
-        xcrEquityFreezeExecutionService.saveDataByUniCode("gateway/api/1/getGqdjbzxrxxByUniscid");
-        xcrAbnormalBusinessOperationsService.saveDataByUniCode("gateway/api/1/getQyycmlxxxxByUniscid");
-        xcrCheckWorkInfoService.saveDataByUniCode("gateway/api/1/getJcgzxxByUniscid");
-        xcrRevisionInformationAgriculturalCollegeAnnualReportService.saveDataByUniCode("gateway/api/1/getNznbxgxxByUniscid");
+        executeServiceCall(() -> xcrELicNcertificateService.saveDataByUniCode("gateway/api/1/getXzxkxxByUniscid"), "gateway/api/1/getXzxkxxByUniscid");
+        executeServiceCall(() -> xcrCompanyInvestmentService.saveDataByUniCode("gateway/api/1/getGdjczxgxxByUniscid"), "gateway/api/1/getGdjczxgxxByUniscid");
+        executeServiceCall(() -> xcrEquityChangeService.saveDataByUniCode("gateway/api/1/getGqczbgxxByUniscid"), "gateway/api/1/getGqczbgxxByUniscid");
+        executeServiceCall(() -> xcrSupplementaryForeignInvestmentService.saveDataByUniCode("gateway/api/1/getWzbcxxByUniscid"), "gateway/api/1/getWzbcxxByUniscid");
+        executeServiceCall(() -> xcrAppointDelegatesService.saveDataByUniCode("gateway/api/1/getWpdbxxByUniscid"), "gateway/api/1/getWpdbxxByUniscid");
+        executeServiceCall(() -> xcrAgriculturalSupplementService.saveDataByUniCode("gateway/api/1/getNzbcxxByUniscid"), "gateway/api/1/getNzbcxxByUniscid");
+        executeServiceCall(() -> xcrDomesticCapitalSupplementService.saveDataByUniCode("gateway/api/1/getNzbcxxByUniscid1"), "gateway/api/1/getNzbcxxByUniscid1");
+        executeServiceCall(() -> xcrInstallmentPaymentService.saveDataByUniCode("gateway/api/1/getFqsjxxByUniscid"), "gateway/api/1/getFqsjxxByUniscid");
+        executeServiceCall(() -> xcrInvestorSubscriptionDetailsService.saveDataByUniCode("gateway/api/1/getTzrrjxxByUniscid"), "gateway/api/1/getTzrrjxxByUniscid");
+        executeServiceCall(() -> xcrNonNaturalPersonContributionService.saveDataByUniCode("gateway/api/1/getFzrrczxxByUniscid"), "gateway/api/1/getFzrrczxxByUniscid");
+        executeServiceCall(() -> xcrNaturalPersonContributionsService.saveDataByUniCode("gateway/api/1/getZrrczxxByUniscid"), "gateway/api/1/getZrrczxxByUniscid");
+        executeServiceCall(() -> xcrHistoryNameService.saveDataByUniCode("gateway/api/1/getLsmcxxByUnscid"), "gateway/api/1/getLsmcxxByUnscid");
+        executeServiceCall(() -> xcrHistoricalLegalRepresentativeService.saveDataByUniCode("gateway/api/1/getLsfddbrxxByUniscid"), "gateway/api/1/getLsfddbrxxByUniscid");
+        //非正常户接触信息
+        executeServiceCall(() -> xcrAbnormalHouseholdTerminationService.saveDataByUniCode("gateway/api/1/getFzchjcxxByUniscid"), "gateway/api/1/getFzchjcxxByUniscid");
+        executeServiceCall(() -> xcrTaxAdministrativePenaltyService.saveDataByUniCode("gateway/api/1/getSwxzcfxxByUniscid"), "gateway/api/1/getSwxzcfxxByUniscid");
+        executeServiceCall(() -> xcrAffiliatedEnterpriseService.saveDataByUniCode("gateway/api/1/getLsqyxxByUniscid"), "gateway/api/1/getLsqyxxByUniscid");
+        executeServiceCall(() -> xcrInstallmentSubscriptionService.saveDataByUniCode("gateway/api/1/getFqrjxxByUniscid"), "gateway/api/1/getFqrjxxByUniscid");
+        executeServiceCall(() -> xcrAdministrativeLicensingAgriculturalCollegesService.saveDataByUniCode("gateway/api/1/getNznbxzxkxxByUniscid"), "gateway/api/1/getNznbxzxkxxByUniscid");
+        executeServiceCall(() -> xcrEnterpriseExceptionListService.saveDataByUniCode("gateway/api/1/getQyycmlxxByUniscid1"), "gateway/api/1/getQyycmlxxByUniscid1");
+        executeServiceCall(() -> xcrInvestorAbnormalRecordService.saveDataByUniCode("gateway/api/1/getQyjyycmlgdxxByUnsicd"), "gateway/api/1/getQyjyycmlgdxxByUnsicd");
+        executeServiceCall(() -> xcrEnterprisePublicityLicenseService.saveDataByUniCode("gateway/api/1/getQygsxkxxByUniscid"), "gateway/api/1/getQygsxkxxByUniscid");
+        executeServiceCall(() -> xcrEnterprisePublicityEquityChangeService.saveDataByUniCode("gateway/api/1/getQygsgqbgxxByUniscid"), "gateway/api/1/getQygsgqbgxxByUniscid");
+        executeServiceCall(() -> xcrSimplifiedCancellationAnnouncementService.saveDataByUniCode("gateway/api/1/getJyzxggxxByUniscid"), "gateway/api/1/getJyzxggxxByUniscid");
+        executeServiceCall(() -> xcrEnterprisePublicityInvestorInformationStatusService.saveDataByUniCode("gateway/api/1/getQygsczrxxqkByUniscid"), "gateway/api/1/getQygsczrxxqkByUniscid");
+        executeServiceCall(() -> xcrEnterprisePublicityDetailsContributionsContributorsService.saveDataByUniCode("gateway/api/1/getCzrsjmxByUniscid"), "gateway/api/1/getCzrsjmxByUniscid");
+        executeServiceCall(() -> xcrEnterprisePublicationSupplySubscribedDetailsInvestorsService.saveDataByUniCode("gateway/api/1/getQygsczrrjmxByUniscid"), "gateway/api/1/getQygsczrrjmxByUniscid");
+        executeServiceCall(() -> xcrRevisionInformationAgriculturalCollegeAnnualReportService.saveDataByUniCode("gateway/api/1/getNznbxgxxByUniscid"), "gateway/api/1/getNznbxgxxByUniscid");
+        executeServiceCall(() -> xcrBasicSupplementAgriculturalCollegeAnnualService.saveDataByUniCode("gateway/api/1/getNznbjbxxbcByUniscid"), "gateway/api/1/getNznbjbxxbcByUniscid");
+        executeServiceCall(() -> xcrEnterpriseBasicInformationService.saveDataByUniCode("gateway/api/1/getQyjbxxByUniscid"), "gateway/api/1/getQyjbxxByUniscid");
+        executeServiceCall(() -> xcrEnterpriseNameApprovalService.saveDataByUniCode("gateway/api/1/getQymcxxByUniscid"), "gateway/api/1/getQymcxxByUniscid");
+        executeServiceCall(() -> xcrSeriousIllegalDishonestEnterprisesService.saveDataByUniCode("gateway/api/1/getYzwfsxqymdBydm"), "gateway/api/1/getYzwfsxqymdBydm");
+        executeServiceCall(() -> xcrSeriousIllegalDishonestEnterprisesDetailService.saveDataByUniCode("gateway/api/1/getYzwfxxxxByUniscid"), "gateway/api/1/getYzwfxxxxByUniscid");
+        executeServiceCall(() -> xcrEquityPledgeInfoService.saveDataByUniCode("gateway/api/1/getGqczdjxxBydm"), "gateway/api/1/getGqczdjxxBydm");
+        executeServiceCall(() -> xcrEquityFreezeService.saveDataByUniCode("gateway/api/1/getGqdjxxByUniscid"), "gateway/api/1/getGqdjxxByUniscid");
+        executeServiceCall(() -> xcrEquityChangeInfoService.saveDataByUniCode("gateway/api/1/getGqbgxxByUniscid"), "gateway/api/1/getGqbgxxByUniscid");
+        executeServiceCall(() -> xcrEquityFreezeExecutionService.saveDataByUniCode("gateway/api/1/getGqdjbzxrxxByUniscid"), "gateway/api/1/getGqdjbzxrxxByUniscid");
+        executeServiceCall(() -> xcrAbnormalBusinessOperationsService.saveDataByUniCode("gateway/api/1/getQyycmlxxxxByUniscid"), "gateway/api/1/getQyycmlxxxxByUniscid");
+        executeServiceCall(() -> xcrCheckWorkInfoService.saveDataByUniCode("gateway/api/1/getJcgzxxByUniscid"), "gateway/api/1/getJcgzxxByUniscid");
         //注销税务登记信息(接口慢导致连接超时)
-//        xcrCancelTaxRegistrationService.saveDataByUniCode("gateway/api/1/getZxswdjxxByUniscid");
+        //executeServiceCall(() -> xcrCancelTaxRegistrationService.saveDataByUniCode("gateway/api/1/getZxswdjxxByUniscid"), "gateway/api/1/getJcgzxxByUniscid");
         //税务登记设立信息
-//        xcrTaxRegistrationEstablishmentService.saveDataByUniCode("gateway/api/1/getSwdjslxxByUniscid");
+        //xcrTaxRegistrationEstablishmentService.saveDataByUniCode("gateway/api/1/getSwdjslxxByUniscid");
         //个体工商户停歇业信息
-//        xcrStopBusinessInformationService.saveDataByUniCode("gateway/api/1/getGtgshtxyxxByUniscid");
+        executeServiceCall(() -> xcrStopBusinessInformationService.saveDataByUniCode("gateway/api/1/getGtgshtxyxxByUniscid"),"gateway/api/1/getGtgshtxyxxByUniscid");;
         //非正常户认定信息
-//        xcrAbnormalHouseholdIdentificationService.saveDataByUniCode("gateway/api/1/getFzchrdxxByUniscid");
+        //xcrAbnormalHouseholdIdentificationService.saveDataByUniCode("gateway/api/1/getFzchrdxxByUniscid");
         //企业所得税申报信息
-//        xcrIncomeTaxReturnService.saveDataByUniCode("gateway/api/1/getQysdssbxxByUniscid1");
+        //xcrIncomeTaxReturnService.saveDataByUniCode("gateway/api/1/getQysdssbxxByUniscid1");
         //财务报表主表
-//        xcrMainFinancialStatementsService.saveDataByUniCode("gateway/api/1/getCwbbzbByUniscid");
+        executeServiceCall(() -> xcrMainFinancialStatementsService.saveDataByUniCode("gateway/api/1/getCwbbzbByUniscid"),"gateway/api/1/getCwbbzbByUniscid");
         //发票开票信息
-//        xcrInvoiceIssuanceService.saveDataByUniCode("gateway/api/1/fpkpxxByUniscid");
+        //xcrInvoiceIssuanceService.saveDataByUniCode("gateway/api/1/fpkpxxByUniscid");
         //非正常户认定解除信息表
-//        xcrConfirmationTerminationService.saveDataByUniCode("gateway/api/1/getFzchrdjcxxbByUniscid");
+        //xcrConfirmationTerminationService.saveDataByUniCode("gateway/api/1/getFzchrdjcxxbByUniscid");
         //纳税人信用等级
-//        xcrTaxpayerCreditRatingService.saveDataByUniCode("gateway/api/1/getNsrxydjByUniscid");
-        //机构客户信息
-//        xcrInstitutionalClientsService.saveDataByUniCode("gateway/api/1/getJgkhxxByUnisicd");
-        //失信记录名单
-//        xcrRecordDishonestyService.saveDataByUniCode("gateway/api/1/getSxjlmdByQymc");
-        //科技计划项目安排表
-//        xcrTechnologyPlanProjectService.saveDataByUniCode("gateway/api/1/getKjjhxmapbByQymc");
-        //科技奖补项目及资金情况
-//        xcrTechnologyAwardSupplementService.saveDataByUniCode("gateway/api/1/getKjjbxmjzjqkByQymc");
-        //科技型中小企业名单
-//        xcrMinorEnterprisesService.saveDataByUniCode("gateway/api/1/getKjxzxqymdByQymc");
-        //国家、省、市创新平台名单
-//        xcrInnovationPlatformService.saveDataByUniCode("gateway/api/1/getCxptmd");
-        //高新技术企业名单
-//        xcrHighTechService.saveDataByUniCode("gateway/api/1/getGxjsqymdByUniscid");
-        //食品生产许可证品种明细
-//        xcrFoodProductionLicenseDetaliService.saveDataByUniCode("gateway/api/1/getSpscxkzpzmxByUniscid");
-        //食品生产法定代表人信息
-//        xcrLegalRepresentativeService.saveDataByUniCode("gateway/api/1/getSpscfddbrxxByUniscid");
-        //食品生产许可证基本信息
-//        xcrFoodProductionLicenseService.saveDataByUniCode("gateway/api/1/getSpscxkzjbxxByUniscid");
-        //食品经营许可证基本信息
-//        xcrFoodBusinessLicenseService.saveDataByUniCode("gateway/api/1/getSpjyxkzjbxxByUniscid");
-        //市场监管_行政许可信息
-//        xcrMsAdministrativeLicenseService.saveDataByUniCode("gateway/api/1/getXzxkxxByUniscid");
-        //联络员信息
-//        xcrContactInformationService.saveDataByUniCode("gateway/api/1/getLlyxxByUniscid");
-        //财务负责人
-//        xcrFinancialManagerService.saveDataByUniCode("gateway/api/1/getCwfzrByUniscid");
-        xcrPersonalRevokeRecordService.saveDataByUniCode("gateway/api/1/getGtdxxxByUniscid");
-        xcrNoticeRecordService.saveDataByUniCode("gateway/api/1/getGsggxxByUniscid");
-        xcrWebsiteInfoService.saveDataByUniCode("gateway/api/1/getGtnbwzhwdxxByUniscid");
-        xcrSmallAndMicroEnterprisesService.saveDataByUniCode("gateway/api/1/getXwqymljbxxByUniscid");
-//        xcrAnnualReportUpdateService.saveDataByUniCode("gateway/api/1/getGtnbxgxxByUniscid");
-        xcrRandomInspectionTaskService.saveDataByUniCode("gateway/api/1/getJcgzxxmlByUniscid");
-        xcrAnnualReportExternalInvestmentService.saveDataByUniCode("gateway/api/1/getQynbdwtzxxByUniscid");
-        xcrExternalGuaranteeService.saveDataByUniCode("gateway/api/1/getQynbdwtgbzxxByUniscid");
-        xcrRevokeInfoService.saveDataByUniCode("gateway/api/1/getDxxxByUniscid");
-        xcrBranchOfficesInfoService.saveDataByUniCode("gateway/api/1/getFzjgbaxxByUniscid1");
-        xcrLicenseInfoService.saveDataByUniCode("gateway/api/1/getXkxxByUniscid");
-        xcrChangeFilingService.saveDataByUniCode("gateway/api/1/getBgbaxxByUniscid");
-        xcrSocialInsuranceDataService.saveDataByUniCode("gateway/api/1/getQynbshbxxxByUniscid");
-        xcrAgriculturalCollegeAnnualReportService.saveDataByUniCode("gateway/api/1/getNznbjbxxByUniscid");
-//        xcrInspectionResultsService.saveDataByUniCode("gateway/api/1/getJcjgxxByUniscid");
-        xcrLicenseInfoService.saveDataByUniCode("gateway/api/1/getXkxxByUniscid");
-        //个体经营者基本信息
-//        xcrIndividualBusinessInformationService.saveDataByUniCode("gateway/api/1/getGtjyzjbxxByUniscid");
-        //个体工商户基本信息
-//        xcrIndustryCommerceService.saveDataByUniCode("gateway/api/1/getGtgshjbxxByUniscid");
-        //个体变更信息
-//        xcrIndividualChangeInformationService.saveDataByUniCode("gateway/api/1/getGtbgxxByUniscid");
-        //个体注销信息
-//        xcrIndividualCancellationService.saveDataByUniCode("gateway/api/1/getGtzxxxByUniscid");
-        //个体经营异常标记信息
-//        xcrIndividualBusinessAbnormalityService.saveDataByUniCode("gateway/api/1/getGtjyycbjxxByUniscid");
-        //迁出信息
-//        xcrMoveOutService.saveDataByUniCode("gateway/api/1/getQcxxByUniscid");
-        //迁入信息
-//        xcrMoveInService.saveDataByUniCode("gateway/api/1/getQrxxByUniscid");
-        //撤销登记信息
-//        xcrDeregistrationService.saveDataByUniCode("gateway/api/1/getCxdjxxByUniscid");
-        //个体许可信息
-//        xcrIndividualLicenseService.saveDataByUniCode("gateway/api/1/getGtxkxxByUniscid");
-        //注销信息
-//        xcrCancellationService.saveDataByUniCode("gateway/api/1/getZxxxByUniscid");
-        //清算基本信息
-//        xcrLiquidationBasicInfoService.saveDataByUniCode("gateway/api/1/getQsjbxxByUniscid1");
-        //清算成员信息
-//        xcrLiquidationMemberInfoService.saveDataByUniCode("gateway/api/1/getQscyxxByUniscid");
-        //经营异常公告批量名单信息
-//        xcrAbnormalOperationAnnouncementService.saveDataByUniCode("gateway/api/1/getJyycggplmdxxByUniscid");
-        //农专异常名录详细信息
-//        xcrFarmSpecialAbnormalDetailService.saveDataByUniCode("gateway/api/1/getNzycmlxxxxByUniscid");
-        //企业年报网站或网店信息
-//        xcrEnterpriseAnnualReportWebsiteService.saveDataByUniCode("gateway/api/1/getQynbwzhwdxxByUniscid");
-        //企业年报股东及出资信息
-//        xcrEnterpriseAnnualReportShareholderService.saveDataByUniCode("gateway/api/1/getQynbgdjczxxByUniscid");
-        //企业年报股权变更信息
-//        xcrEnterpriseAnnualReportEquityChangeService.saveDataByUniCode("gateway/api/1/getQynbgqbgxxByUniscid");
-        //个体撤销登记信息
-//        xcrRevokeRegistrationService.saveDataByUniCode("gateway/api/1/getGtcxdjxxByUniscid");
-        //简易注销异议信息
-//        xcrIndividualCancellationObjectionService.saveDataByUniCode("gateway/api/1/getJyzxyyxxByUniscid");
-        //企业年报基本信息
-//        xcrAnnualReportBaseInfoService.saveDataByUniCode("gateway/api/1/getQynbjbxxByUniscid1");
-        //环保处罚决定情况信息
-//        xcrEnvironmentalPenaltyDecisionService.saveDataByUniCode("gateway/api/1/getHbcfjdqkxxByUniscid");
-        //企业排污许可信息
-        xcrEnterprisePollutionPermitInfoService.saveDataByUniCode("gateway/api/1/getQypwxkxxByUniscid");
-        //重点排污单位名录
-//        xcrKeyPollutionSourcesService.saveDataByUniCode("gateway/api/1/getZdpwdwmlByShxyfwm");
+        executeServiceCall(() -> xcrTaxpayerCreditRatingService.saveDataByUniCode("gateway/api/1/getNsrxydjByUniscid"), "gateway/api/1/getNsrxydjByUniscid");
+        // 机构客户信息
+        executeServiceCall(() -> xcrInstitutionalClientsService.saveDataByUniCode("gateway/api/1/getJgkhxxByUnisicd"), "gateway/api/1/getJgkhxxByUnisicd");
+        // 失信记录名单
+        executeServiceCall(() -> xcrRecordDishonestyService.saveDataByUniCode("gateway/api/1/getSxjlmdByQymc"), "gateway/api/1/getSxjlmdByQymc");
+        // 科技计划项目安排表
+        executeServiceCall(() -> xcrTechnologyPlanProjectService.saveDataByUniCode("gateway/api/1/getKjjhxmapbByQymc"), "gateway/api/1/getKjjhxmapbByQymc");
+        // 科技奖补项目及资金情况
+        executeServiceCall(() -> xcrTechnologyAwardSupplementService.saveDataByUniCode("gateway/api/1/getKjjbxmjzjqkByQymc"), "gateway/api/1/getKjjbxmjzjqkByQymc");
+        // 科技型中小企业名单
+        executeServiceCall(() -> xcrMinorEnterprisesService.saveDataByUniCode("gateway/api/1/getKjxzxqymdByQymc"), "gateway/api/1/getKjxzxqymdByQymc");
+        // 国家、省、市创新平台名单
+        executeServiceCall(() -> xcrInnovationPlatformService.saveDataByUniCode("gateway/api/1/getCxptmd"), "gateway/api/1/getCxptmd");
+        // 高新技术企业名单
+        executeServiceCall(() -> xcrHighTechService.saveDataByUniCode("gateway/api/1/getGxjsqymdByUniscid"), "gateway/api/1/getGxjsqymdByUniscid");
+        // 食品生产许可证品种明细
+        executeServiceCall(() -> xcrFoodProductionLicenseDetaliService.saveDataByUniCode("gateway/api/1/getSpscxkzpzmxByUniscid"), "gateway/api/1/getSpscxkzpzmxByUniscid");
+        // 食品生产法定代表人信息
+        executeServiceCall(() -> xcrLegalRepresentativeService.saveDataByUniCode("gateway/api/1/getSpscfddbrxxByUniscid"), "gateway/api/1/getSpscfddbrxxByUniscid");
+        // 食品生产许可证基本信息
+        executeServiceCall(() -> xcrFoodProductionLicenseService.saveDataByUniCode("gateway/api/1/getSpscxkzjbxxByUniscid"), "gateway/api/1/getSpscxkzjbxxByUniscid");
+        // 食品经营许可证基本信息
+        executeServiceCall(() -> xcrFoodBusinessLicenseService.saveDataByUniCode("gateway/api/1/getSpjyxkzjbxxByUniscid"), "gateway/api/1/getSpjyxkzjbxxByUniscid");
+        // 市场监管_行政许可信息
+        executeServiceCall(() -> xcrMsAdministrativeLicenseService.saveDataByUniCode("gateway/api/1/getXzxkxxByUniscid"), "gateway/api/1/getXzxkxxByUniscid");
+        // 联络员信息
+        executeServiceCall(() -> xcrContactInformationService.saveDataByUniCode("gateway/api/1/getLlyxxByUniscid"), "gateway/api/1/getLlyxxByUniscid");
+        // 财务负责人
+        executeServiceCall(() -> xcrFinancialManagerService.saveDataByUniCode("gateway/api/1/getCwfzrByUniscid"), "gateway/api/1/getCwfzrByUniscid");
+        executeServiceCall(() -> xcrPersonalRevokeRecordService.saveDataByUniCode("gateway/api/1/getGtdxxxByUniscid"), "gateway/api/1/getGtdxxxByUniscid");
+        executeServiceCall(() -> xcrNoticeRecordService.saveDataByUniCode("gateway/api/1/getGsggxxByUniscid"), "gateway/api/1/getGsggxxByUniscid");
+        executeServiceCall(() -> xcrWebsiteInfoService.saveDataByUniCode("gateway/api/1/getGtnbwzhwdxxByUniscid"), "gateway/api/1/getGtnbwzhwdxxByUniscid");
+        executeServiceCall(() -> xcrSmallAndMicroEnterprisesService.saveDataByUniCode("gateway/api/1/getXwqymljbxxByUniscid"), "gateway/api/1/getXwqymljbxxByUniscid");
+        executeServiceCall(() -> xcrAnnualReportUpdateService.saveDataByUniCode("gateway/api/1/getGtnbxgxxByUniscid"), "gateway/api/1/getGtnbxgxxByUniscid");
+        executeServiceCall(() -> xcrRandomInspectionTaskService.saveDataByUniCode("gateway/api/1/getJcgzxxmlByUniscid"), "gateway/api/1/getJcgzxxmlByUniscid");
+        executeServiceCall(() -> xcrAnnualReportExternalInvestmentService.saveDataByUniCode("gateway/api/1/getQynbdwtzxxByUniscid"), "gateway/api/1/getQynbdwtzxxByUniscid");
+        executeServiceCall(() -> xcrExternalGuaranteeService.saveDataByUniCode("gateway/api/1/getQynbdwtgbzxxByUniscid"), "gateway/api/1/getQynbdwtgbzxxByUniscid");
+        executeServiceCall(() -> xcrRevokeInfoService.saveDataByUniCode("gateway/api/1/getDxxxByUniscid"), "gateway/api/1/getDxxxByUniscid");
+        executeServiceCall(() -> xcrBranchOfficesInfoService.saveDataByUniCode("gateway/api/1/getFzjgbaxxByUniscid1"), "gateway/api/1/getFzjgbaxxByUniscid1");
+        executeServiceCall(() -> xcrLicenseInfoService.saveDataByUniCode("gateway/api/1/getXkxxByUniscid"), "gateway/api/1/getXkxxByUniscid");
+        executeServiceCall(() -> xcrChangeFilingService.saveDataByUniCode("gateway/api/1/getBgbaxxByUniscid"), "gateway/api/1/getBgbaxxByUniscid");
+        executeServiceCall(() -> xcrSocialInsuranceDataService.saveDataByUniCode("gateway/api/1/getQynbshbxxxByUniscid"), "gateway/api/1/getQynbshbxxxByUniscid");
+        executeServiceCall(() -> xcrAgriculturalCollegeAnnualReportService.saveDataByUniCode("gateway/api/1/getNznbjbxxByUniscid"), "gateway/api/1/getNznbjbxxByUniscid");
+        executeServiceCall(() -> xcrInspectionResultsService.saveDataByUniCode("gateway/api/1/getJcjgxxByUniscid"), "gateway/api/1/getJcjgxxByUniscid");
+        // 个体经营者基本信息
+        executeServiceCall(() -> xcrIndividualBusinessInformationService.saveDataByUniCode("gateway/api/1/getGtjyzjbxxByUniscid"), "gateway/api/1/getGtjyzjbxxByUniscid");
+        // 个体工商户基本信息
+        executeServiceCall(() -> xcrIndustryCommerceService.saveDataByUniCode("gateway/api/1/getGtgshjbxxByUniscid"), "gateway/api/1/getGtgshjbxxByUniscid");
+        // 个体变更信息
+        executeServiceCall(() -> xcrIndividualChangeInformationService.saveDataByUniCode("gateway/api/1/getGtbgxxByUniscid"), "gateway/api/1/getGtbgxxByUniscid");
+        // 个体注销信息
+        executeServiceCall(() -> xcrIndividualCancellationService.saveDataByUniCode("gateway/api/1/getGtzxxxByUniscid"), "gateway/api/1/getGtzxxxByUniscid");
+        // 个体经营异常标记信息
+        executeServiceCall(() -> xcrIndividualBusinessAbnormalityService.saveDataByUniCode("gateway/api/1/getGtjyycbjxxByUniscid"), "gateway/api/1/getGtjyycbjxxByUniscid");
+        // 迁出信息
+        executeServiceCall(() -> xcrMoveOutService.saveDataByUniCode("gateway/api/1/getQcxxByUniscid"), "gateway/api/1/getQcxxByUniscid");
+        // 迁入信息
+        executeServiceCall(() -> xcrMoveInService.saveDataByUniCode("gateway/api/1/getQrxxByUniscid"), "gateway/api/1/getQrxxByUniscid");
+        // 撤销登记信息
+        executeServiceCall(() -> xcrDeregistrationService.saveDataByUniCode("gateway/api/1/getCxdjxxByUniscid"), "gateway/api/1/getCxdjxxByUniscid");
+        // 个体许可信息
+        // executeServiceCall(() -> xcrIndividualLicenseService.saveDataByUniCode("gateway/api/1/getGtxkxxByUniscid"), "gateway/api/1/getGtxkxxByUniscid");
+        // 注销信息
+        executeServiceCall(() -> xcrCancellationService.saveDataByUniCode("gateway/api/1/getZxxxByUniscid"), "gateway/api/1/getZxxxByUniscid");
+        // 清算基本信息
+        executeServiceCall(() -> xcrLiquidationBasicInfoService.saveDataByUniCode("gateway/api/1/getQsjbxxByUniscid1"), "gateway/api/1/getQsjbxxByUniscid1");
+        // 清算成员信息
+        executeServiceCall(() -> xcrLiquidationMemberInfoService.saveDataByUniCode("gateway/api/1/getQscyxxByUniscid"), "gateway/api/1/getQscyxxByUniscid");
+        // 经营异常公告批量名单信息
+        executeServiceCall(() -> xcrAbnormalOperationAnnouncementService.saveDataByUniCode("gateway/api/1/getJyycggplmdxxByUniscid"), "gateway/api/1/getJyycggplmdxxByUniscid");
+        // 农专异常名录详细信息
+        executeServiceCall(() -> xcrFarmSpecialAbnormalDetailService.saveDataByUniCode("gateway/api/1/getNzycmlxxxxByUniscid"), "gateway/api/1/getNzycmlxxxxByUniscid");
+        // 企业年报网站或网店信息
+        executeServiceCall(() -> xcrEnterpriseAnnualReportWebsiteService.saveDataByUniCode("gateway/api/1/getQynbwzhwdxxByUniscid"), "gateway/api/1/getQynbwzhwdxxByUniscid");
+        // 企业年报股东及出资信息
+        // executeServiceCall(() -> xcrEnterpriseAnnualReportShareholderService.saveDataByUniCode("gateway/api/1/getQynbgdjczxxByUniscid"), "gateway/api/1/getQynbgdjczxxByUniscid");
+        // 企业年报股权变更信息
+        executeServiceCall(() -> xcrEnterpriseAnnualReportEquityChangeService.saveDataByUniCode("gateway/api/1/getQynbgqbgxxByUniscid"), "gateway/api/1/getQynbgqbgxxByUniscid");
+        // 个体撤销登记信息
+        executeServiceCall(() -> xcrRevokeRegistrationService.saveDataByUniCode("gateway/api/1/getGtcxdjxxByUniscid"), "gateway/api/1/getGtcxdjxxByUniscid");
+        // 简易注销异议信息
+        executeServiceCall(() -> xcrIndividualCancellationObjectionService.saveDataByUniCode("gateway/api/1/getJyzxyyxxByUniscid"), "gateway/api/1/getJyzxyyxxByUniscid");
+        // 环保处罚决定情况信息
+        executeServiceCall(() -> xcrEnvironmentalPenaltyDecisionService.saveDataByUniCode("gateway/api/1/getHbcfjdqkxxByUniscid"), "gateway/api/1/getHbcfjdqkxxByUniscid");
+        // 企业排污许可信息
+        executeServiceCall(() -> xcrEnterprisePollutionPermitInfoService.saveDataByUniCode("gateway/api/1/getQypwxkxxByUniscid"), "gateway/api/1/getQypwxkxxByUniscid");
+        // 重点排污单位名录
+        executeServiceCall(() -> xcrKeyPollutionSourcesService.saveDataByUniCode("gateway/api/1/getZdpwdwmlByShxyfwm"), "gateway/api/1/getZdpwdwmlByShxyfwm");
+        // 农专年报网站或网店信息
+        executeServiceCall(() -> xcrAgriculturalSpecializedWebsiteService.saveDataByUniCode("gateway/api/1/nznbwzhwdxxByUniscid"), "gateway/api/1/nznbwzhwdxxByUniscid");
+        // 主要成员信息
+        executeServiceCall(() -> xcrMajorMembersService.saveDataByUniCode("gateway/api/1/zyryxxByUniscid"), "gateway/api/1/zyryxxByUniscid");
         return "成功";
     }
+    /**
+     * 执行服务调用,并处理可能出现的异常。
+     * @param runnable 服务的具体方法
+     * @param apiEndpoint API端点
+     */
+    private void executeServiceCall(Runnable runnable, String apiEndpoint) {
+        try {
+            runnable.run();
+        } catch (Exception e) {
+            // 可以在这里记录错误日志
+            log.error(e.toString(),apiEndpoint+"接口同步失败");
+        }
+    }
     @GetMapping("/b")
     public String test(String address,String paramsValue){
         List<String> creditCodes = (List<String>) redisService.getList("creditCodes").get(0);

+ 2 - 0
data-service/src/main/java/com/zksy/data/service/impl/XcrAgriculturalSpecializedWebsiteServiceImpl.java

@@ -1,6 +1,7 @@
 package com.zksy.data.service.impl;
 
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.zksy.data.annotation.XhDataLogRecord;
 import com.zksy.data.domain.po.XcrAgriculturalSpecializedWebsite;
 import com.zksy.data.domain.po.XcrAgriculturalSupplement;
 import com.zksy.data.domain.response.XcrAgriculturalSpecializedWebsiteResponse;
@@ -33,6 +34,7 @@ public class XcrAgriculturalSpecializedWebsiteServiceImpl extends ServiceImpl<Xc
 
     @Override
     @Transactional(rollbackFor = Exception.class)
+    @XhDataLogRecord("同步农专年报网站或网店信息")
     public void saveDataByUniCode(String address) {
         //模拟从数据库中取数据大约为3000-4000条
         List<String> creditCodes = (List<String>) redisService.getList("creditCodes").get(0);

+ 15 - 13
data-service/src/main/java/com/zksy/data/service/impl/XcrEnterprisePollutionPermitInfoServiceImpl.java

@@ -22,14 +22,14 @@ import java.util.Vector;
 import java.util.stream.Collectors;
 
 /**
-* @author 邵洋
-* @description 针对表【xcr_enterprise_pollution_permit_info(企业排污许可信息表)】的数据库操作Service实现
-* @createDate 2024-10-25 10:12:46
-*/
+ * @author 邵洋
+ * @description 针对表【xcr_enterprise_pollution_permit_info(企业排污许可信息表)】的数据库操作Service实现
+ * @createDate 2024-10-25 10:12:46
+ */
 @Service
 @Slf4j
 public class XcrEnterprisePollutionPermitInfoServiceImpl extends ServiceImpl<XcrEnterprisePollutionPermitInfoMapper, XcrEnterprisePollutionPermitInfo>
-    implements XcrEnterprisePollutionPermitInfoService{
+        implements XcrEnterprisePollutionPermitInfoService {
     @Autowired
     private XhRequestUtil xhRequestUtil;
     @Autowired
@@ -48,7 +48,7 @@ public class XcrEnterprisePollutionPermitInfoServiceImpl extends ServiceImpl<Xcr
                     XcrEnterprisePollutionPermitInfo.class,
                     "SHXYDM"
             );
-            if(list != null){
+            if (list != null) {
                 toDatabaseList.addAll(list);
             }
         });
@@ -58,7 +58,8 @@ public class XcrEnterprisePollutionPermitInfoServiceImpl extends ServiceImpl<Xcr
                 "dd-MMM-yy HH.mm.ss.SSSSSSSSS a", // 09-7月 -20 12.00.00.000000000 上午
                 "yyyy/MM/dd HH:mm:ss.SSS", // 2020/04/16 00:00:00.000
                 "yyyy-MM-dd",
-                "yyyy.MM.dd"
+                "yyyy.MM.dd",
+                "MM-MMMM -yy hh.mm.ss.SSSSSSSSS a"
         };
         List<XcrEnterprisePollutionPermitInfo> enterprisePollutionPermitInfoList = toDatabaseList.stream().map(q -> {
             Date date = parseDate(q.getXKZFFSJ(), datePatterns);
@@ -69,18 +70,19 @@ public class XcrEnterprisePollutionPermitInfoServiceImpl extends ServiceImpl<Xcr
         this.saveBatch(enterprisePollutionPermitInfoList);
         log.info("企业排污许可信息同步完成");
     }
+
     // 尝试多种日期格式进行解析
     private Date parseDate(String dateString, String[] patterns) {
         if (dateString == null || dateString.trim().isEmpty()) {
             log.warn("日期字符串为空或空白: {}", dateString);
             return null; // 或者返回一个默认日期
         }
-            for (String pattern : patterns) {
-                try {
-                    // 使用正确的 Locale
-                    Locale locale = pattern.contains("a") ? Locale.CHINA : Locale.US;
-                    SimpleDateFormat inputFormat = new SimpleDateFormat(pattern, locale);
-                    return inputFormat.parse(dateString);
+        for (String pattern : patterns) {
+            try {
+                // 使用正确的 Locale
+                Locale locale = pattern.contains("a") ? Locale.CHINA : Locale.US;
+                SimpleDateFormat inputFormat = new SimpleDateFormat(pattern, locale);
+                return inputFormat.parse(dateString);
             } catch (ParseException e) {
                 // 继续尝试下一个格式
             }

+ 2 - 0
data-service/src/main/java/com/zksy/data/service/impl/XcrMajorMembersServiceImpl.java

@@ -1,6 +1,7 @@
 package com.zksy.data.service.impl;
 
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.zksy.data.annotation.XhDataLogRecord;
 import com.zksy.data.domain.po.XcrMajorMembers;
 import com.zksy.data.domain.po.XcrMinorEnterprises;
 import com.zksy.data.domain.response.XcrMajorMembersResponse;
@@ -33,6 +34,7 @@ public class XcrMajorMembersServiceImpl extends ServiceImpl<XcrMajorMembersMappe
 
     @Override
     @Transactional(rollbackFor = Exception.class)
+    @XhDataLogRecord("主要人员信息")
     public void saveDataByUniCode(String address) {
         //模拟从数据库中取数据大约为3000-4000条
         List<String> creditCodes = (List<String>) redisService.getList("creditCodes").get(0);