344 lines
16 KiB
Go
344 lines
16 KiB
Go
package services
|
||
|
||
import (
|
||
"context"
|
||
"encoding/json"
|
||
"fmt"
|
||
|
||
"tyapi-server/internal/application/api/commands"
|
||
"tyapi-server/internal/config"
|
||
"tyapi-server/internal/domains/api/services/processors"
|
||
"tyapi-server/internal/domains/api/services/processors/comb"
|
||
"tyapi-server/internal/domains/api/services/processors/dwbg"
|
||
"tyapi-server/internal/domains/api/services/processors/flxg"
|
||
"tyapi-server/internal/domains/api/services/processors/ivyz"
|
||
"tyapi-server/internal/domains/api/services/processors/jrzq"
|
||
"tyapi-server/internal/domains/api/services/processors/pdfg"
|
||
"tyapi-server/internal/domains/api/services/processors/qcxg"
|
||
"tyapi-server/internal/domains/api/services/processors/qygl"
|
||
"tyapi-server/internal/domains/api/services/processors/test"
|
||
"tyapi-server/internal/domains/api/services/processors/yysy"
|
||
"tyapi-server/internal/domains/product/services"
|
||
"tyapi-server/internal/infrastructure/external/alicloud"
|
||
"tyapi-server/internal/infrastructure/external/jiguang"
|
||
"tyapi-server/internal/infrastructure/external/muzi"
|
||
"tyapi-server/internal/infrastructure/external/shujubao"
|
||
"tyapi-server/internal/infrastructure/external/shumai"
|
||
"tyapi-server/internal/infrastructure/external/tianyancha"
|
||
"tyapi-server/internal/infrastructure/external/westdex"
|
||
"tyapi-server/internal/infrastructure/external/xingwei"
|
||
"tyapi-server/internal/infrastructure/external/yushan"
|
||
"tyapi-server/internal/infrastructure/external/zhicha"
|
||
"tyapi-server/internal/shared/interfaces"
|
||
)
|
||
|
||
var (
|
||
ErrDatasource = processors.ErrDatasource
|
||
ErrSystem = processors.ErrSystem
|
||
ErrInvalidParam = processors.ErrInvalidParam
|
||
ErrNotFound = processors.ErrNotFound
|
||
)
|
||
|
||
type ApiRequestService struct {
|
||
// 可注入依赖，如第三方服务、模型等
|
||
westDexService *westdex.WestDexService
|
||
muziService *muzi.MuziService
|
||
yushanService *yushan.YushanService
|
||
tianYanChaService *tianyancha.TianYanChaService
|
||
alicloudService *alicloud.AlicloudService
|
||
validator interfaces.RequestValidator
|
||
processorDeps *processors.ProcessorDependencies
|
||
combService *comb.CombService
|
||
config *config.Config
|
||
}
|
||
|
||
func NewApiRequestService(
|
||
westDexService *westdex.WestDexService,
|
||
shujubaoService *shujubao.ShujubaoService,
|
||
muziService *muzi.MuziService,
|
||
yushanService *yushan.YushanService,
|
||
tianYanChaService *tianyancha.TianYanChaService,
|
||
alicloudService *alicloud.AlicloudService,
|
||
zhichaService *zhicha.ZhichaService,
|
||
xingweiService *xingwei.XingweiService,
|
||
jiguangService *jiguang.JiguangService,
|
||
shumaiService *shumai.ShumaiService,
|
||
validator interfaces.RequestValidator,
|
||
productManagementService *services.ProductManagementService,
|
||
cfg *config.Config,
|
||
) *ApiRequestService {
|
||
// 创建组合包服务
|
||
combService := comb.NewCombService(productManagementService)
|
||
|
||
// 创建处理器依赖容器
|
||
processorDeps := processors.NewProcessorDependencies(westDexService, shujubaoService, muziService, yushanService, tianYanChaService, alicloudService, zhichaService, xingweiService, jiguangService, shumaiService, validator, combService)
|
||
|
||
// 统一注册所有处理器
|
||
registerAllProcessors(combService)
|
||
|
||
return &ApiRequestService{
|
||
westDexService: westDexService,
|
||
muziService: muziService,
|
||
yushanService: yushanService,
|
||
tianYanChaService: tianYanChaService,
|
||
alicloudService: alicloudService,
|
||
validator: validator,
|
||
processorDeps: processorDeps,
|
||
combService: combService,
|
||
config: cfg,
|
||
}
|
||
}
|
||
|
||
// registerAllProcessors 统一注册所有处理器
|
||
func registerAllProcessors(combService *comb.CombService) {
|
||
// 定义所有处理器映射
|
||
processorMap := map[string]processors.ProcessorFunc{
|
||
// FLXG系列处理器
|
||
"FLXG0V3B": flxg.ProcessFLXG0V3Bequest,
|
||
"FLXG0V4B": flxg.ProcessFLXG0V4BRequest,
|
||
"FLXG162A": flxg.ProcessFLXG162ARequest,
|
||
"FLXG3D56": flxg.ProcessFLXG3D56Request,
|
||
"FLXG54F5": flxg.ProcessFLXG54F5Request,
|
||
"FLXG5876": flxg.ProcessFLXG5876Request,
|
||
"FLXG75FE": flxg.ProcessFLXG75FERequest,
|
||
"FLXG9687": flxg.ProcessFLXG9687Request,
|
||
"FLXG970F": flxg.ProcessFLXG970FRequest,
|
||
"FLXGC9D1": flxg.ProcessFLXGC9D1Request,
|
||
"FLXGCA3D": flxg.ProcessFLXGCA3DRequest,
|
||
"FLXGDEC7": flxg.ProcessFLXGDEC7Request,
|
||
"FLXG8A3F": flxg.ProcessFLXG8A3FRequest,
|
||
"FLXG5B2E": flxg.ProcessFLXG5B2ERequest,
|
||
"FLXG0687": flxg.ProcessFLXG0687Request,
|
||
"FLXGBC21": flxg.ProcessFLXGBC21Request,
|
||
"FLXGDEA8": flxg.ProcessFLXGDEA8Request,
|
||
"FLXGDEA9": flxg.ProcessFLXGDEA9Request,
|
||
"FLXG5A3B": flxg.ProcessFLXG5A3BRequest,
|
||
"FLXG9C1D": flxg.ProcessFLXG9C1DRequest,
|
||
"FLXG2E8F": flxg.ProcessFLXG2E8FRequest,
|
||
"FLXG7E8F": flxg.ProcessFLXG7E8FRequest,
|
||
"FLXG3A9B": flxg.ProcessFLXG3A9BRequest,
|
||
"FLXGK5D2": flxg.ProcessFLXGK5D2Request,
|
||
// JRZQ系列处理器
|
||
"JRZQ8203": jrzq.ProcessJRZQ8203Request,
|
||
"JRZQ0A03": jrzq.ProcessJRZQ0A03Request,
|
||
"JRZQ4AA8": jrzq.ProcessJRZQ4AA8Request,
|
||
"JRZQDCBE": jrzq.ProcessJRZQDCBERequest,
|
||
"JRZQACAB": jrzq.ProcessJRZQACABERequest, // 银行卡四要素
|
||
"JRZQ09J8": jrzq.ProcessJRZQ09J8Request,
|
||
"JRZQ1D09": jrzq.ProcessJRZQ1D09Request,
|
||
"JRZQ3C7B": jrzq.ProcessJRZQ3C7BRequest,
|
||
"JRZQ8A2D": jrzq.ProcessJRZQ8A2DRequest,
|
||
"JRZQ5E9F": jrzq.ProcessJRZQ5E9FRequest,
|
||
"JRZQ4B6C": jrzq.ProcessJRZQ4B6CRequest,
|
||
"JRZQ7F1A": jrzq.ProcessJRZQ7F1ARequest,
|
||
"JRZQ9E2A": jrzq.ProcessJRZQ9E2ARequest,
|
||
"JRZQ6F2A": jrzq.ProcessJRZQ6F2ARequest,
|
||
"JRZQ8B3C": jrzq.ProcessJRZQ8B3CRequest,
|
||
"JRZQ9D4E": jrzq.ProcessJRZQ9D4ERequest,
|
||
"JRZQ0L85": jrzq.ProcessJRZQ0L85Request,
|
||
"JRZQ2F8A": jrzq.ProcessJRZQ2F8ARequest,
|
||
"JRZQ1E7B": jrzq.ProcessJRZQ1E7BRequest,
|
||
"JRZQ3C9R": jrzq.ProcessJRZQ3C9RRequest,
|
||
"JRZQ0B6Y": jrzq.ProcessJRZQ0B6YRequest,
|
||
"JRZQ9A1W": jrzq.ProcessJRZQ9A1WRequest,
|
||
"JRZQ8F7C": jrzq.ProcessJRZQ8F7CRequest,
|
||
"JRZQ1W4X": jrzq.ProcessJRZQ1W4XRequest,
|
||
"JRZQ3P01": jrzq.ProcessJRZQ3P01Request,
|
||
"JRZQ3AG6": jrzq.ProcessJRZQ3AG6Request,
|
||
"JRZQO6L7": jrzq.ProcessJRZQO6L7Request, // 全国自然人经济特征评分模型v3 简版
|
||
"JRZQO7L1": jrzq.ProcessJRZQO7L1Request, // 全国自然人经济特征评分模型v4 详版
|
||
"JRZQS7G0": jrzq.ProcessJRZQS7G0Request, // 社保综合评分V1
|
||
|
||
// QYGL系列处理器
|
||
"QYGL8261": qygl.ProcessQYGL8261Request,
|
||
"QYGL2ACD": qygl.ProcessQYGL2ACDRequest,
|
||
"QYGL45BD": qygl.ProcessQYGL45BDRequest,
|
||
"QYGL6F2D": qygl.ProcessQYGL6F2DRequest,
|
||
"QYGL8271": qygl.ProcessQYGL8271Request,
|
||
"QYGLB4C0": qygl.ProcessQYGLB4C0Request,
|
||
"QYGL23T7": qygl.ProcessQYGL23T7Request, // 企业三要素验证
|
||
"QYGL5A3C": qygl.ProcessQYGL5A3CRequest, // 对外投资历史
|
||
"QYGL8B4D": qygl.ProcessQYGL8B4DRequest, // 融资历史
|
||
"QYGL9E2F": qygl.ProcessQYGL9E2FRequest, // 行政处罚
|
||
"QYGL7C1A": qygl.ProcessQYGL7C1ARequest, // 经营异常
|
||
"QYGL3F8E": qygl.ProcessQYGL3F8ERequest, // 人企关系加强版
|
||
"QYGL7D9A": qygl.ProcessQYGL7D9ARequest, // 欠税公告
|
||
"QYGL4B2E": qygl.ProcessQYGL4B2ERequest, // 税收违法
|
||
"COMENT01": qygl.ProcessCOMENT01Request, // 企业风险报告
|
||
"QYGL5F6A": qygl.ProcessQYGL5F6ARequest, // 企业相关查询
|
||
"QYGL2B5C": qygl.ProcessQYGL2B5CRequest, // 企业联系人实际经营地址
|
||
"QYGL6S1B": qygl.ProcessQYGL6S1BRequest, //董监高司法综合信息核验
|
||
"QYGL9T1Q": qygl.ProcessQYGL9T1QRequest, //全国企业借贷意向验证查询_V1
|
||
"QYGL5A9T": qygl.ProcessQYGL5A9TRequest, //全国企业各类工商风险统计数量查询
|
||
"QYGL2S0W": qygl.ProcessQYGL2S0WRequest, //失信被执行企业个人查询
|
||
"QYGL5CMP": qygl.ProcessQYGL5CMPRequest, //企业五要素验证
|
||
"QYGL66SL": qygl.ProcessQYGL66SLRequest, //全国企业司法模型服务查询_V1
|
||
"QYGL2NAO": qygl.ProcessQYGL2naoRequest, //股权变更
|
||
"QYGLNIO8": qygl.ProcessQYGLNIO8Request, //企业基本信息
|
||
"QYGLP0HT": qygl.ProcessQYGLP0HTRequest, //股权穿透
|
||
"QYGL5S1I": qygl.ProcessQYGL5S1IRequest, //企业司法涉诉I
|
||
|
||
// YYSY系列处理器
|
||
"YYSYD50F": yysy.ProcessYYSYD50FRequest,
|
||
"YYSY09CD": yysy.ProcessYYSY09CDRequest,
|
||
"YYSY4B21": yysy.ProcessYYSY4B21Request,
|
||
"YYSY4B37": yysy.ProcessYYSY4B37Request,
|
||
"YYSY6F2E": yysy.ProcessYYSY6F2ERequest,
|
||
"YYSYBE08": yysy.ProcessYYSYBE08Request,
|
||
"YYSYF7DB": yysy.ProcessYYSYF7DBRequest,
|
||
"YYSY4F2E": yysy.ProcessYYSY4F2ERequest,
|
||
"YYSY8B1C": yysy.ProcessYYSY8B1CRequest,
|
||
"YYSY6D9A": yysy.ProcessYYSY6D9ARequest,
|
||
"YYSY3E7F": yysy.ProcessYYSY3E7FRequest,
|
||
"YYSY8F3A": yysy.ProcessYYSY8F3ARequest,
|
||
"YYSY9A1B": yysy.ProcessYYSY9A1BRequest,
|
||
"YYSY8C2D": yysy.ProcessYYSY8C2DRequest,
|
||
"YYSY7D3E": yysy.ProcessYYSY7D3ERequest,
|
||
"YYSY9E4A": yysy.ProcessYYSY9E4ARequest,
|
||
"YYSY9F1B": yysy.ProcessYYSY9F1BYequest,
|
||
"YYSY6F2B": yysy.ProcessYYSY6F2BRequest,
|
||
"YYSY3M8S": yysy.ProcessYYSY3M8SRequest, //运营商二要素查询
|
||
"YYSYC4R9": yysy.ProcessYYSYC4R9Request, //运营商三要素详版查询
|
||
"YYSYH6D2": yysy.ProcessYYSYH6D2Request, //运营商三要素简版查询
|
||
"YYSYP0T4": yysy.ProcessYYSYP0T4Request, //在网时长查询
|
||
"YYSYE7V5": yysy.ProcessYYSYE7V5Request, //手机在网状态查询
|
||
"YYSYS9W1": yysy.ProcessYYSYS9W1Request, //手机携号转网查询
|
||
"YYSYK8R3": yysy.ProcessYYSYK8R3Request, //手机空号检测查询
|
||
"YYSYH6F3": yysy.ProcessYYSYH6F3Request, //运营商三要素即时版查询
|
||
|
||
// IVYZ系列处理器
|
||
"IVYZ0B03": ivyz.ProcessIVYZ0B03Request,
|
||
"IVYZ2125": ivyz.ProcessIVYZ2125Request,
|
||
"IVYZ385E": ivyz.ProcessIVYZ385ERequest,
|
||
"IVYZ5733": ivyz.ProcessIVYZ5733Request,
|
||
"IVYZ9363": ivyz.ProcessIVYZ9363Request,
|
||
"IVYZ9A2B": ivyz.ProcessIVYZ9A2BRequest,
|
||
"IVYZADEE": ivyz.ProcessIVYZADEERequest,
|
||
"IVYZ7F2A": ivyz.ProcessIVYZ7F2ARequest,
|
||
"IVYZ4E8B": ivyz.ProcessIVYZ4E8BRequest,
|
||
"IVYZ1C9D": ivyz.ProcessIVYZ1C9DRequest,
|
||
"IVYZGZ08": ivyz.ProcessIVYZGZ08Request,
|
||
"IVYZ2A8B": ivyz.ProcessIVYZ2A8BRequest,
|
||
"IVYZ7C9D": ivyz.ProcessIVYZ7C9DRequest,
|
||
"IVYZ5E3F": ivyz.ProcessIVYZ5E3FRequest,
|
||
"IVYZ7F3A": ivyz.ProcessIVYZ7F3ARequest,
|
||
"IVYZ3P9M": ivyz.ProcessIVYZ3P9MRequest,
|
||
"IVYZ3A7F": ivyz.ProcessIVYZ3A7FRequest,
|
||
"IVYZ9D2E": ivyz.ProcessIVYZ9D2ERequest,
|
||
"IVYZ81NC": ivyz.ProcessIVYZ81NCRequest,
|
||
"IVYZ6G7H": ivyz.ProcessIVYZ6G7HRequest,
|
||
"IVYZ8I9J": ivyz.ProcessIVYZ8I9JRequest,
|
||
"IVYZ9K2L": ivyz.ProcessIVYZ9K2LRequest,
|
||
"IVYZ2C1P": ivyz.ProcessIVYZ2C1PRequest,
|
||
"IVYZP2Q6": ivyz.ProcessIVYZP2Q6Request,
|
||
"IVYZ2B2T": ivyz.ProcessIVYZ2B2TRequest, //能力资质核验（学历）
|
||
"IVYZ5A9O": ivyz.ProcessIVYZ5A9ORequest, //全国⾃然⼈⻛险评估评分模型
|
||
"IVYZ6M8P": ivyz.ProcessIVYZ6M8PRequest, //职业资格证书
|
||
"IVYZ9H2M": ivyz.ProcessIVYZ9H2MRequest, //极光个人婚姻查询（V2版）
|
||
"IVYZZQT3": ivyz.ProcessIVYZZQT3Request, //人脸比对V3
|
||
"IVYZBPQ2": ivyz.ProcessIVYZBPQ2Request, //人脸比对V2
|
||
"IVYZSFEL": ivyz.ProcessIVYZSFELRequest, //全国自然人人像三要素核验_V1
|
||
"IVYZ0S0D": ivyz.ProcessIVYZ0S0DRequest, //劳动仲裁信息查询（个人版）
|
||
"IVYZ1J7H": ivyz.ProcessIVYZ1J7HRequest, //行驶证核查v2
|
||
"IVYZ9K7F": ivyz.ProcessIVYZ9K7FRequest, //身份证实名认证即时版
|
||
"IVYZA1B3": ivyz.ProcessIVYZA1B3Request, //公安三要素人脸识别
|
||
"IVYZN2P8": ivyz.ProcessIVYZN2P8Request, //身份证实名认证政务版
|
||
"IVYZX5QZ": ivyz.ProcessIVYZX5QZRequest, //活体检测
|
||
"IVYZX5Q2": ivyz.ProcessIVYZX5Q2Request, //活体识别步骤二
|
||
|
||
// COMB系列处理器 - 只注册有自定义逻辑的组合包
|
||
"COMB86PM": comb.ProcessCOMB86PMRequest, // 有自定义逻辑：重命名ApiCode
|
||
"COMBHZY2": comb.ProcessCOMBHZY2Request, // 自定义处理：生成合规报告
|
||
"COMBWD01": comb.ProcessCOMBWD01Request, // 自定义处理：将返回结构从数组改为对象
|
||
|
||
// QCXG系列处理器
|
||
"QCXG7A2B": qcxg.ProcessQCXG7A2BRequest,
|
||
"QCXG9P1C": qcxg.ProcessQCXG9P1CRequest,
|
||
"QCXG8A3D": qcxg.ProcessQCXG8A3DRequest,
|
||
"QCXG6B4E": qcxg.ProcessQCXG6B4ERequest,
|
||
"QCXG4896": qcxg.ProcessQCXG4896Request,
|
||
"QCXG5F3A": qcxg.ProcessQCXG5F3ARequest, // 极光个人车辆查询
|
||
"QCXG4D2E": qcxg.ProcessQCXG4D2ERequest, // 极光名下车辆数量查询
|
||
"QCXGJJ2A": qcxg.ProcessQCXGJJ2ARequest, // vin码查车辆信息(一对多)
|
||
"QCXGGJ3A": qcxg.ProcessQCXGGJ3ARequest, // 车辆vin码查询号牌
|
||
"QCXGYTS2": qcxg.ProcessQCXGYTS2Request, // 车辆二要素核验v2
|
||
"QCXGP00W": qcxg.ProcessQCXGP00WRequest, // 车辆出险详版查询
|
||
"QCXGGB2Q": qcxg.ProcessQCXGGB2QRequest, // 车辆二要素核验V1
|
||
"QCXG4I1Z": qcxg.ProcessQCXG4I1ZRequest, // 车辆过户详版查询
|
||
"QCXG1H7Y": qcxg.ProcessQCXG1H7YRequest, // 车辆过户简版查询
|
||
"QCXG3Z3L": qcxg.ProcessQCXG3Z3LRequest, // 车辆维保详细版查询
|
||
"QCXG3Y6B": qcxg.ProcessQCXG3Y6BRequest, // 车辆维保简版查询
|
||
"QCXG2T6S": qcxg.ProcessQCXG2T6SRequest, // 车辆里程记录（品牌查询）
|
||
"QCXG1U4U": qcxg.ProcessQCXG1U4URequest, //
|
||
"QCXG9F5C": qcxg.ProcessQCXG9F5CERequest, //疑似营运车辆注册平台数 10386
|
||
"QCXG3B8Z": qcxg.ProcessQCXG3B8ZRequest, //疑似运营车辆查询（月度里程）10268
|
||
"QCXGP1W3": qcxg.ProcessQCXGP1W3Request, //疑似运营车辆查询（季度里程）10269
|
||
"QCXGM7R9": qcxg.ProcessQCXGM7R9Request, //疑似运营车辆查询（半年度里程）10270
|
||
"QCXG5U0Z": qcxg.ProcessQCXG5U0ZRequest, // 车辆静态信息查询 10479
|
||
"QCXGY7F2": qcxg.ProcessQCXGY7F2Request, // 二手车VIN估值 10443
|
||
|
||
// DWBG系列处理器 - 多维报告
|
||
"DWBG6A2C": dwbg.ProcessDWBG6A2CRequest,
|
||
"DWBG8B4D": dwbg.ProcessDWBG8B4DRequest,
|
||
"DWBG7F3A": dwbg.ProcessDWBG7F3ARequest,
|
||
|
||
// FLXG系列处理器 - 风险管控 (包含原FXHY功能)
|
||
"FLXG8B4D": flxg.ProcessFLXG8B4DRequest,
|
||
|
||
// TEST系列处理器 - 测试用处理器
|
||
"TEST001": test.ProcessTestRequest,
|
||
"TEST002": test.ProcessTestErrorRequest,
|
||
"TEST003": test.ProcessTestTimeoutRequest,
|
||
|
||
// PDFG系列处理器 - PDF生成
|
||
"PDFG01GZ": pdfg.ProcessPDFG01GZRequest,
|
||
}
|
||
|
||
// 批量注册到组合包服务
|
||
for apiCode, processor := range processorMap {
|
||
combService.RegisterProcessor(apiCode, processor)
|
||
}
|
||
|
||
// 同时设置全局处理器映射
|
||
RequestProcessors = processorMap
|
||
}
|
||
|
||
// 注册API处理器 - 现在通过registerAllProcessors统一管理
|
||
var RequestProcessors map[string]processors.ProcessorFunc
|
||
|
||
// PreprocessRequestApi 调用指定的请求处理函数
|
||
func (a *ApiRequestService) PreprocessRequestApi(ctx context.Context, apiCode string, params []byte, options *commands.ApiCallOptions, callContext *processors.CallContext) ([]byte, error) {
|
||
// 设置Options和CallContext到依赖容器
|
||
deps := a.processorDeps.WithOptions(options).WithCallContext(callContext)
|
||
|
||
// 将apiCode放入context，供外部服务使用
|
||
ctx = context.WithValue(ctx, "api_code", apiCode)
|
||
// 将config放入context，供处理器使用
|
||
ctx = context.WithValue(ctx, "config", a.config)
|
||
|
||
// 1. 优先查找已注册的自定义处理器
|
||
if processor, exists := RequestProcessors[apiCode]; exists {
|
||
return processor(ctx, params, deps)
|
||
}
|
||
|
||
// 2. 检查是否为组合包（COMB开头），使用通用组合包处理器
|
||
if len(apiCode) >= 4 && apiCode[:4] == "COMB" {
|
||
return a.processGenericCombRequest(ctx, apiCode, params, deps)
|
||
}
|
||
|
||
return nil, fmt.Errorf("%s: 未找到处理器: %s", ErrSystem, apiCode)
|
||
}
|
||
|
||
// processGenericCombRequest 通用组合包处理器
|
||
func (a *ApiRequestService) processGenericCombRequest(ctx context.Context, apiCode string, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) {
|
||
// 调用组合包服务处理请求
|
||
// 这里不需要验证参数，因为组合包的参数验证由各个子处理器负责
|
||
combinedResult, err := deps.CombService.ProcessCombRequest(ctx, params, deps, apiCode)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
|
||
// 直接返回组合结果，无任何自定义处理
|
||
return json.Marshal(combinedResult)
|
||
}
|