diff --git a/internal/domains/api/dto/api_request_dto.go b/internal/domains/api/dto/api_request_dto.go index 47223ed..9808ef0 100644 --- a/internal/domains/api/dto/api_request_dto.go +++ b/internal/domains/api/dto/api_request_dto.go @@ -617,7 +617,7 @@ type QYGLJ0Q1Req struct { EntCode string `json:"ent_code" validate:"omitempty,validUSCI"` } -type QYGLDJG3Req struct { +type FLXGDJG3Req struct { IDCard string `json:"id_card" validate:"required,validIDCard"` } type QYGLDJ12Req struct { diff --git a/internal/domains/api/services/api_request_service.go b/internal/domains/api/services/api_request_service.go index 73f1998..02baba3 100644 --- a/internal/domains/api/services/api_request_service.go +++ b/internal/domains/api/services/api_request_service.go @@ -129,16 +129,16 @@ func NewApiRequestServiceWithRepos( registerAllProcessors(combService) return &ApiRequestService{ - westDexService: westDexService, - muziService: muziService, - yushanService: yushanService, - tianYanChaService: tianYanChaService, - alicloudService: alicloudService, - validator: validator, - processorDeps: processorDeps, - combService: combService, - config: cfg, - reportRepo: reportRepo, + westDexService: westDexService, + muziService: muziService, + yushanService: yushanService, + tianYanChaService: tianYanChaService, + alicloudService: alicloudService, + validator: validator, + processorDeps: processorDeps, + combService: combService, + config: cfg, + reportRepo: reportRepo, } } @@ -171,6 +171,7 @@ func registerAllProcessors(combService *comb.CombService) { "FLXG7E8F": flxg.ProcessFLXG7E8FRequest, "FLXG3A9B": flxg.ProcessFLXG3A9BRequest, "FLXGK5D2": flxg.ProcessFLXGK5D2Request, + "FLXGDJG3": flxg.ProcessFLXGDJG3Request, //董监高司法综合信息核验 // JRZQ系列处理器 "JRZQ8203": jrzq.ProcessJRZQ8203Request, "JRZQ0A03": jrzq.ProcessJRZQ0A03Request, @@ -236,9 +237,11 @@ func registerAllProcessors(combService *comb.CombService) { "QYGLJ1U9": qygl.ProcessQYGLJ1U9Request, //企业全景报告(聚合 QYGLUY3S/QYGLJ0Q1/QYGL5S1I) "QYGLJ0Q1": qygl.ProcessQYGLJ0Q1Request, //企业股权结构全景查询 "QYGLUY3S": qygl.ProcessQYGLUY3SRequest, //企业经营状态全景查询 - "YYSY35TA": yysy.ProcessYYSY35TARequest, //运营商归属地数卖 + "QYGLDJ12": qygl.ProcessQYGLDJ12Request, //企业年报信息核验 + "QYGL8844": qygl.ProcessQYGL8848Request, //企业税收违法核查 // YYSY系列处理器 + "YYSY35TA": yysy.ProcessYYSY35TARequest, //运营商归属地数卖 "YYSYD50F": yysy.ProcessYYSYD50FRequest, "YYSY09CD": yysy.ProcessYYSY09CDRequest, "YYSY4B21": yysy.ProcessYYSY4B21Request, diff --git a/internal/domains/api/services/form_config_service.go b/internal/domains/api/services/form_config_service.go index d1faab6..fdfe56b 100644 --- a/internal/domains/api/services/form_config_service.go +++ b/internal/domains/api/services/form_config_service.go @@ -263,6 +263,9 @@ func (s *FormConfigServiceImpl) getDTOStruct(ctx context.Context, apiCode string "JRZQOCRE": &dto.JRZQOCREReq{}, //银行卡OCR数卖 "JRZQOCRY": &dto.JRZQOCRYReq{}, //银行卡OCR数据宝 "YYSY35TA": &dto.YYSY35TAReq{}, //运营商归属地数卖 + "QYGLDJ12": &dto.QYGLDJ12Req{}, //企业年报信息核验 + "FLXGDJG3": &dto.FLXGDJG3Req{}, //董监高司法综合信息核验 + "QYGL8844": &dto.QYGLDJ12Req{}, //企业税收违法核查 } // 优先返回已配置的DTO diff --git a/internal/domains/api/services/processors/flxg/qygldjg3_processor.go b/internal/domains/api/services/processors/flxg/flxgdjg3_processor.go similarity index 91% rename from internal/domains/api/services/processors/flxg/qygldjg3_processor.go rename to internal/domains/api/services/processors/flxg/flxgdjg3_processor.go index 33f9d72..56d0d1c 100644 --- a/internal/domains/api/services/processors/flxg/qygldjg3_processor.go +++ b/internal/domains/api/services/processors/flxg/flxgdjg3_processor.go @@ -10,9 +10,9 @@ import ( "tyapi-server/internal/infrastructure/external/shujubao" ) -// ProcessQYGLDJG3Request QYGLDJG3 董监高司法综合信息核验 API 处理方法(使用数据宝服务示例) -func ProcessQYGLDJG3Request(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) { - var paramsDto dto.QYGLDJG3Req +// ProcessFLXGDJG3Request FLXGDJG3 董监高司法综合信息核验 API 处理方法(使用数据宝服务示例) +func ProcessFLXGDJG3Request(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) { + var paramsDto dto.FLXGDJG3Req if err := json.Unmarshal(params, ¶msDto); err != nil { return nil, errors.Join(processors.ErrSystem, err) }