f

internal/application/api/api_application_service.go

@@ -609,8 +609,6 @@ func (s *ApiApplicationServiceImpl) GetUserApiCalls(ctx context.Context, userID
 	// 转换为响应DTO
 	var items []dto.ApiCallRecordResponse
 	for _, call := range calls {
-		// 出于安全考虑，不再在数据库中存储或解密真实请求参数
-		// 这里只保留数据库中的原始占位值（通常为空字符串）
 		requestParamsStr := call.RequestParams
 
 		item := dto.ApiCallRecordResponse{

internal/application/user/user_application_service_impl.go

@@ -339,19 +339,19 @@ func (s *UserApplicationServiceImpl) ListUsers(ctx context.Context, query *queri
 				EnterpriseAddress: user.EnterpriseInfo.EnterpriseAddress,
 				CreatedAt:         user.EnterpriseInfo.CreatedAt,
 			}
-			
+
 			// 获取企业合同信息
 			contracts, err := s.contractService.FindByUserID(ctx, user.ID)
 			if err == nil && len(contracts) > 0 {
 				contractItems := make([]*responses.ContractInfoItem, 0, len(contracts))
 				for _, contract := range contracts {
 					contractItems = append(contractItems, &responses.ContractInfoItem{
-						ID:              contract.ID,
-						ContractName:    contract.ContractName,
-						ContractType:    string(contract.ContractType),
+						ID:               contract.ID,
+						ContractName:     contract.ContractName,
+						ContractType:     string(contract.ContractType),
 						ContractTypeName: contract.GetContractTypeName(),
-						ContractFileURL: contract.ContractFileURL,
-						CreatedAt:       contract.CreatedAt,
+						ContractFileURL:  contract.ContractFileURL,
+						CreatedAt:        contract.CreatedAt,
 					})
 				}
 				item.EnterpriseInfo.Contracts = contractItems
@@ -411,19 +411,19 @@ func (s *UserApplicationServiceImpl) GetUserDetail(ctx context.Context, userID s
 			EnterpriseAddress: user.EnterpriseInfo.EnterpriseAddress,
 			CreatedAt:         user.EnterpriseInfo.CreatedAt,
 		}
-		
+
 		// 获取企业合同信息
 		contracts, err := s.contractService.FindByUserID(ctx, user.ID)
 		if err == nil && len(contracts) > 0 {
 			contractItems := make([]*responses.ContractInfoItem, 0, len(contracts))
 			for _, contract := range contracts {
 				contractItems = append(contractItems, &responses.ContractInfoItem{
-					ID:              contract.ID,
-					ContractName:    contract.ContractName,
-					ContractType:    string(contract.ContractType),
+					ID:               contract.ID,
+					ContractName:     contract.ContractName,
+					ContractType:     string(contract.ContractType),
 					ContractTypeName: contract.GetContractTypeName(),
-					ContractFileURL: contract.ContractFileURL,
-					CreatedAt:       contract.CreatedAt,
+					ContractFileURL:  contract.ContractFileURL,
+					CreatedAt:        contract.CreatedAt,
 				})
 			}
 			item.EnterpriseInfo.Contracts = contractItems

internal/domains/api/dto/api_request_dto.go

@@ -113,6 +113,19 @@ type QYGL2ACDReq struct {
 	LegalPerson string `json:"legal_person" validate:"required,min=1,validName"`
 	EntCode     string `json:"ent_code" validate:"required,validUSCI"`
 }
+type QYGLUY3SReq struct {
+	EntName  string `json:"ent_name" validate:"omitempty,min=1,validEnterpriseName"`
+	EntRegno string `json:"ent_reg_no" validate:"omitempty"`
+	EntCode  string `json:"ent_code" validate:"omitempty,validUSCI"`
+}
+
+type JRZQOCRYReq struct {
+	PhotoData string `json:"photo_data" validate:"required,validBase64Image"`
+}
+type JRZQOCREReq struct {
+	PhotoData string `json:"photo_data" validate:"omitempty,validBase64Image"`
+	ImageUrl  string `json:"image_url" validate:"omitempty,url"`
+}
 
 type YYSYK9R4Req struct {
 	MobileNo string `json:"mobile_no" validate:"required,min=11,max=11,validMobileNo"`
@@ -120,6 +133,10 @@ type YYSYK9R4Req struct {
 	Name     string `json:"name" validate:"required,min=1,validName"`
 }
 
+type YYSY35TAReq struct {
+	MobileNo string `json:"mobile_no" validate:"required,min=11,max=11,validMobileNo"`
+}
+
 type QCXG9F5CReq struct {
 	PlateNo string `json:"plate_no" validate:"required"`
 }
@@ -403,7 +420,7 @@ type COMENT01Req struct {
 }
 
 type JRZQ09J8Req struct {
-	MobileNo   string `json:"mobile_no" validate:"omitempty,min=11,max=11,validMobileNo"`
+	MobileNo   string `json:"mobile_no" validate:"required,min=11,max=11,validMobileNo"`
 	IDCard     string `json:"id_card" validate:"required,validIDCard"`
 	Name       string `json:"name" validate:"required,min=1,validName"`
 	Authorized string `json:"authorized" validate:"required,oneof=0 1"`
@@ -584,10 +601,18 @@ type YYSY6F2BReq struct {
 	MobileNo string `json:"mobile_no" validate:"required,min=11,max=11,validMobileNo"`
 }
 
+type IVYZOCR1Req struct {
+	PhotoData string `json:"photo_data" validate:"omitempty,validBase64Image"`
+	ImageUrl  string `json:"image_url" validate:"omitempty,url"`
+}
 type YYSY8B1CReq struct {
 	MobileNo string `json:"mobile_no" validate:"required,min=11,max=11,validMobileNo"`
 }
 
+type QYGLJ0Q1Req struct {
+	EntName string `json:"ent_name" validate:"omitempty,min=1,validEnterpriseName"`
+	EntCode string `json:"ent_code" validate:"omitempty,validUSCI"`
+}
 type YYSY6D9AReq struct {
 	MobileNo   string `json:"mobile_no" validate:"required,min=11,max=11,validMobileNo"`
 	IDCard     string `json:"id_card" validate:"required,validIDCard"`

internal/domains/api/entities/api_call.go

@@ -80,7 +80,7 @@ func NewApiCall(accessId, requestParams, clientIp string) (*ApiCall, error) {
 		AccessId:      accessId,
 		TransactionId: GenerateTransactionID(),
 		ClientIp:      clientIp,
-		RequestParams: "",
+		RequestParams: requestParams,
 		Status:        ApiCallStatusPending,
 		StartAt:       time.Now(),
 	}, nil

internal/domains/api/services/api_request_service.go

@@ -145,10 +145,12 @@ func registerAllProcessors(combService *comb.CombService) {
 		"JRZQ1W4X": jrzq.ProcessJRZQ1W4XRequest,
 		"JRZQ3P01": jrzq.ProcessJRZQ3P01Request,
 		"JRZQ3AG6": jrzq.ProcessJRZQ3AG6Request,
-		"JRZQO6L7": jrzq.ProcessJRZQO6L7Request, // 全国自然人经济特征评分模型v3 简版
-		"JRZQO7L1": jrzq.ProcessJRZQO7L1Request, // 全国自然人经济特征评分模型v4 详版
-		"JRZQS7G0": jrzq.ProcessJRZQS7G0Request, // 社保综合评分V1
-		"JRZQ1P5G": jrzq.ProcessJRZQ1P5GRequest, // 全国自然人借贷压力指数查询（2）
+		"JRZQO6L7": jrzq.ProcessJRZQO6L7Request,  // 全国自然人经济特征评分模型v3 简版
+		"JRZQO7L1": jrzq.ProcessJRZQO7L1Request,  // 全国自然人经济特征评分模型v4 详版
+		"JRZQS7G0": jrzq.ProcessJRZQS7G0Request,  // 社保综合评分V1
+		"JRZQ1P5G": jrzq.ProcessJRZQ1P5GRequest,  // 全国自然人借贷压力指数查询（2）
+		"JRZQOCRE": jrzq.ProcessJRZQOCREERequest, // 银行卡OCR数卖
+		"JRZQOCRY": jrzq.ProcessJRZQOCRYERequest, // 银行卡OCR数据宝
 
 		// QYGL系列处理器
 		"QYGL8261": qygl.ProcessQYGL8261Request,
@@ -178,6 +180,9 @@ func registerAllProcessors(combService *comb.CombService) {
 		"QYGLNIO8": qygl.ProcessQYGLNIO8Request, //企业基本信息
 		"QYGLP0HT": qygl.ProcessQYGLP0HTRequest, //股权穿透
 		"QYGL5S1I": qygl.ProcessQYGL5S1IRequest, //企业司法涉诉I
+		"QYGLJ0Q1": qygl.ProcessQYGLJ0Q1Request, //企业股权结构全景查询
+		"QYGLUY3S": qygl.ProcessQYGLUY3SRequest, //企业经营状态全景查询
+		"YYSY35TA": yysy.ProcessYYSY35TARequest, //运营商归属地数卖
 
 		// YYSY系列处理器
 		"YYSYD50F": yysy.ProcessYYSYD50FRequest,
@@ -248,6 +253,8 @@ func registerAllProcessors(combService *comb.CombService) {
 		"IVYZN2P8": ivyz.ProcessIVYZN2P8Request, //身份证实名认证政务版
 		"IVYZX5QZ": ivyz.ProcessIVYZX5QZRequest, //活体检测
 		"IVYZX5Q2": ivyz.ProcessIVYZX5Q2Request, //活体识别步骤二
+		"IVYZOCR1": ivyz.ProcessIVYZOCR1Request, //身份证OCR
+		"IVYZOCR2": ivyz.ProcessIVYZOCR2Request, //身份证OCR2数卖
 
 		// COMB系列处理器 - 只注册有自定义逻辑的组合包
 		"COMB86PM": comb.ProcessCOMB86PMRequest, // 有自定义逻辑：重命名ApiCode

internal/domains/api/services/form_config_service.go

@@ -255,6 +255,13 @@ func (s *FormConfigServiceImpl) getDTOStruct(ctx context.Context, apiCode string
 		"YYSYK9R4": &dto.YYSYK9R4Req{}, //全网手机三要素验证1979周更新版
 		"QCXG3M7Z": &dto.QCXG3M7ZReq{}, //人车关系核验（ETC）10093 月更
 		"JRZQ1P5G": &dto.JRZQ1P5GReq{}, //全国自然人借贷压力指数查询（2）
+		"IVYZOCR1": &dto.IVYZOCR1Req{}, //身份证OCR
+		"IVYZOCR2": &dto.IVYZOCR1Req{}, //身份证OCR2数卖
+		"QYGLJ0Q1": &dto.QYGLJ0Q1Req{}, //企业股权结构全景查询
+		"QYGLUY3S": &dto.QYGLUY3SReq{}, //企业全量信息核验V2 可用
+		"JRZQOCRE": &dto.JRZQOCREReq{}, //银行卡OCR数卖
+		"JRZQOCRY": &dto.JRZQOCRYReq{}, //银行卡OCR数据宝
+		"YYSY35TA": &dto.YYSY35TAReq{}, //运营商归属地数卖
 	}
 
 	// 优先返回已配置的DTO
@@ -438,6 +445,7 @@ func (s *FormConfigServiceImpl) generateFieldLabel(jsonTag string) string {
 		"ent_name":                 "企业名称",
 		"legal_person":             "法人姓名",
 		"ent_code":                 "企业代码",
+		"ent_reg_no":               "企业注册号",
 		"auth_date":                "授权日期",
 		"date_range":               "日期范围",
 		"time_range":               "时间范围",
@@ -459,7 +467,7 @@ func (s *FormConfigServiceImpl) generateFieldLabel(jsonTag string) string {
 		"plate_type":               "号牌类型",
 		"vin_code":                 "车辆识别代号VIN码",
 		"return_type":              "返回类型",
-		"photo_data":               "人脸图片",
+		"photo_data":               "入参图片base64编码",
 		"owner_type":               "企业主类型",
 		"type":                     "查询类型",
 		"query_reason_id":          "查询原因ID",
@@ -471,7 +479,7 @@ func (s *FormConfigServiceImpl) generateFieldLabel(jsonTag string) string {
 		"notice_model":             "车辆型号",
 		"vlphoto_data":             "行驶证图片",
 		"carplate_type":            "车辆号牌类型",
-		"image_url":                "行驶证图片地址",
+		"image_url":                "入参图片地址",
 		"reg_url":                  "车辆登记证图片地址",
 		"token":                    "token采集及获取结果时所使用的凭证，有效期2个小时，在此时效内，应用侧可以发起采集请求（重复的采集所触发的结果会被忽略）和结果查询",
 		"vehicle_name":             "车型名称",
@@ -500,6 +508,7 @@ func (s *FormConfigServiceImpl) generateExampleValue(fieldType reflect.Type, jso
 		"ent_name":                 "示例企业有限公司",
 		"legal_person":             "王五",
 		"ent_code":                 "91110000123456789X",
+		"ent_reg_no":               "110000000123456",
 		"auth_date":                "20240101-20241231",
 		"date_range":               "20240101-20241231",
 		"time_range":               "09:00-18:00",
@@ -571,6 +580,7 @@ func (s *FormConfigServiceImpl) generatePlaceholder(jsonTag string, fieldType st
 		"ent_name":                 "请输入企业全称",
 		"legal_person":             "请输入法人真实姓名",
 		"ent_code":                 "请输入统一社会信用代码",
+		"ent_reg_no":               "请输入企业注册号（统一社会信用代码）",
 		"auth_date":                "请输入授权日期范围（YYYYMMDD-YYYYMMDD）",
 		"date_range":               "请输入日期范围（YYYYMMDD-YYYYMMDD）",
 		"time_range":               "请输入时间范围（HH:MM-HH:MM）",
@@ -592,7 +602,7 @@ func (s *FormConfigServiceImpl) generatePlaceholder(jsonTag string, fieldType st
 		"plate_type":               "请选择号牌类型（01或02）",
 		"vin_code":                 "请输入17位车辆识别代号VIN码",
 		"return_type":              "请选择返回类型",
-		"photo_data":               "请输入base64编码的人脸图片（支持JPG、BMP、PNG格式）",
+		"photo_data":               "请输入base64编码的入参图片（支持JPG、BMP、PNG格式）",
 		"ownerType":                "请选择企业主类型",
 		"type":                     "请选择查询类型",
 		"query_reason_id":          "请选择查询原因ID",
@@ -644,6 +654,7 @@ func (s *FormConfigServiceImpl) generateDescription(jsonTag string, validation s
 		"ent_name":                 "请输入企业全称",
 		"legal_person":             "请输入法人真实姓名",
 		"ent_code":                 "请输入统一社会信用代码",
+		"ent_reg_no":               "请输入企业注册号（统一社会信用代码）",
 		"auth_date":                "请输入授权日期范围，格式：YYYYMMDD-YYYYMMDD，且日期范围必须包括今天",
 		"date_range":               "请输入日期范围，格式：YYYYMMDD-YYYYMMDD",
 		"time_range":               "请输入时间范围，格式：HH:MM-HH:MM",
@@ -665,7 +676,7 @@ func (s *FormConfigServiceImpl) generateDescription(jsonTag string, validation s
 		"plate_type":               "号牌类型：01-小型汽车；02-大型汽车（可选）",
 		"vin_code":                 "请输入17位车辆识别代号VIN码（Vehicle Identification Number）",
 		"return_type":              "返回类型：1-专业和学校名称数据返回编码形式（默认）；2-专业和学校名称数据返回中文名称",
-		"photo_data":               "人脸图片（必填）：base64编码的图片数据，仅支持JPG、BMP、PNG三种格式",
+		"photo_data":               "入参图片：base64编码的图片数据，仅支持JPG、BMP、PNG三种格式",
 		"owner_type":               "企业主类型编码：1-法定代表人；2-主要人员；3-自然人股东；4-法定代表人及自然人股东；5-其他",
 		"type":                     "查询类型：per-人员，ent-企业  ",
 		"query_reason_id":          "查询原因ID：1-授信审批；2-贷中管理；3-贷后管理；4-异议处理；5-担保查询；6-租赁资质审查；7-融资租赁审批；8-借贷撮合查询；9-保险审批；10-资质审核；11-风控审核；12-企业背调",
@@ -677,7 +688,7 @@ func (s *FormConfigServiceImpl) generateDescription(jsonTag string, validation s
 		"notice_model":             "车辆型号",
 		"vlphoto_data":             "行驶证图片:base64编码的图片数据，仅支持JPG、BMP、PNG三种格式",
 		"carplate_type":            "车辆号牌类型：01-大型汽车；02-小型汽车；03-使馆汽车；04-领馆汽车；05-境外汽车；06-外籍汽车；07-普通摩托车；08-轻便摩托车；09-使馆摩托车；10-领馆摩托车；11-境外摩托车；12-外籍摩托车；13-低速车；14-拖拉机；15-挂车；16-教练汽车；17-教练摩托车；20-临时入境汽车；21-临时入境摩托车；22-临时行驶车；23-警用汽车；24-警用摩托；51-新能源大型车；52-新能源小型车",
-		"image_url":                "行驶证图片地址（必填）：请提供行驶证的图片URL地址",
+		"image_url":                "入参图片url地址",
 		"reg_url":                  "车辆登记证图片地址（非必填）：请提供车辆登记证的图片URL地址",
 		"token":                    "token采集及获取结果时所使用的凭证，有效期2个小时，在此时效内，应用侧可以发起采集请求（重复的采集所触发的结果会被忽略）和结果查询",
 		"vehicle_name":             "车型名称，示例：凌派 2020款 锐·混动 1.5L 锐·舒适版",

internal/domains/api/services/processors/dwbg/dwbg8b4d_processor.go

@@ -109,7 +109,7 @@ func collectAPIData(ctx context.Context, params dto.DWBG8B4DReq, deps *processor
 		{
 			apiCode: "FLXG8B4D",
 			params: map[string]interface{}{
-				"mobile_no": params.MobileNo,
+				"mobile_no":  params.MobileNo,
 				"authorized": "1",
 			},
 		},
@@ -117,9 +117,9 @@ func collectAPIData(ctx context.Context, params dto.DWBG8B4DReq, deps *processor
 		{
 			apiCode: "JRZQ8A2D",
 			params: map[string]interface{}{
-				"mobile_no": params.MobileNo,
-				"id_card":   params.IDCard,
-				"name":      params.Name,
+				"mobile_no":  params.MobileNo,
+				"id_card":    params.IDCard,
+				"name":       params.Name,
 				"authorized": "1",
 			},
 		},
@@ -127,9 +127,9 @@ func collectAPIData(ctx context.Context, params dto.DWBG8B4DReq, deps *processor
 		{
 			apiCode: "JRZQ1D09",
 			params: map[string]interface{}{
-				"mobile_no": params.MobileNo,
-				"id_card":   params.IDCard,
-				"name":      params.Name,
+				"mobile_no":  params.MobileNo,
+				"id_card":    params.IDCard,
+				"name":       params.Name,
 				"authorized": "1",
 			},
 		},
@@ -155,9 +155,9 @@ func collectAPIData(ctx context.Context, params dto.DWBG8B4DReq, deps *processor
 		{
 			apiCode: "JRZQ5E9F",
 			params: map[string]interface{}{
-				"mobile_no": params.MobileNo,
-				"id_card":   params.IDCard,
-				"name":      params.Name,
+				"mobile_no":  params.MobileNo,
+				"id_card":    params.IDCard,
+				"name":       params.Name,
 				"authorized": "1",
 			},
 		},
@@ -165,8 +165,8 @@ func collectAPIData(ctx context.Context, params dto.DWBG8B4DReq, deps *processor
 		{
 			apiCode: "FLXGDEA9",
 			params: map[string]interface{}{
-				"id_card":   params.IDCard,
-				"name":      params.Name,
+				"id_card":    params.IDCard,
+				"name":       params.Name,
 				"authorized": "1",
 			},
 		},
@@ -211,7 +211,7 @@ func collectAPIData(ctx context.Context, params dto.DWBG8B4DReq, deps *processor
 			}()
 
 			paramsBytes, err := json.Marshal(ac.params)
-	if err != nil {
+			if err != nil {
 				log.Warn("序列化API参数失败",
 					zap.String("api_code", ac.apiCode),
 					zap.Error(err),
@@ -266,7 +266,7 @@ func callProcessor(ctx context.Context, apiCode string, params []byte, deps *pro
 			return nil, fmt.Errorf("未找到处理器: %s", apiCode)
 		}
 		respBytes, err := processor(ctx, params, deps)
-	if err != nil {
+		if err != nil {
 			return nil, err
 		}
 		var data interface{}
@@ -387,7 +387,7 @@ func buildBaseInfo(apiData map[string]interface{}, params dto.DWBG8B4DReq, log *
 			// 从运营商三要素获取户籍所在地（address字段）
 			if address, ok := yysyMap["address"].(string); ok && address != "" {
 				baseInfo["location"] = address
-		} else {
+			} else {
 				// 如果address不存在，尝试从身份证号获取
 				if location := getLocationFromIDCard(params.IDCard); location != "" {
 					baseInfo["location"] = location
@@ -496,7 +496,7 @@ func buildStandLiveInfo(apiData map[string]interface{}, log *zap.Logger) map[str
 					}
 				}
 			}
-			
+
 			if status != "" {
 				// "一致" -> "0", "不一致" -> "1"
 				if status == "一致" {
@@ -629,7 +629,7 @@ func buildVerifyRule(apiData map[string]interface{}, log *zap.Logger) string {
 // buildFraudRule 构建反欺诈规则（综合考虑fraudScore、特殊名单和借选指数风险）
 func buildFraudRule(apiData map[string]interface{}, log *zap.Logger) string {
 	fraudScore := getFraudScore(apiData)
-	
+
 	// 如果fraudScore无效，检查特殊名单和借选指数
 	if fraudScore == -1 {
 		// 检查特殊名单
@@ -654,7 +654,7 @@ func buildFraudRule(apiData map[string]interface{}, log *zap.Logger) string {
 		}
 		return "低风险"
 	}
-	
+
 	// 根据fraudScore判断风险等级
 	if fraudScore >= 80 {
 		return "高风险"
@@ -1039,13 +1039,13 @@ func buildRiskWarning(apiData map[string]interface{}, log *zap.Logger) map[strin
 						if variableValue, ok := variable["variableValue"].(map[string]interface{}); ok {
 							// 检查近期申请频率（近7天、近15天、近1个月）
 							checkRecentApplicationFrequency(variableValue, &riskWarning)
-							
+
 							// 检查银行/非银申请次数
 							checkBankApplicationFrequency(variableValue, &riskWarning)
-							
+
 							// 检查偿债压力（从借选指数评估获取）
 							checkDebtPressure(apiData, &riskWarning)
-							
+
 							// 计算借贷评估风险计数
 							calculateLoanRiskCounts(variableValue, &riskWarning)
 						}
@@ -1152,21 +1152,21 @@ func buildRiskWarning(apiData map[string]interface{}, log *zap.Logger) map[strin
 	// 计算总风险点数量（排除Counts字段和level字段）
 	totalRiskCounts := 0
 	excludeFields := map[string]bool{
-		"totalRiskCounts":           true,
+		"totalRiskCounts":            true,
 		"level":                      true,
-		"sfhyfxRiskCounts":          true,
-		"sfhyfxRiskHighCounts":      true,
-		"sfhyfxRiskMiddleCounts":    true,
-		"gazdyrhyRiskCounts":        true,
+		"sfhyfxRiskCounts":           true,
+		"sfhyfxRiskHighCounts":       true,
+		"sfhyfxRiskMiddleCounts":     true,
+		"gazdyrhyRiskCounts":         true,
 		"gazdyrhyRiskHighCounts":     true,
 		"gazdyrhyRiskMiddleCounts":   true,
-		"yqfxRiskCounts":            true,
-		"yqfxRiskHighCounts":        true,
-		"yqfxRiskMiddleCounts":      true,
-		"zlfxpgRiskCounts":          true,
-		"zlfxpgRiskHighCounts":      true,
-		"zlfxpgRiskMiddleCounts":    true,
-		"jdpgRiskCounts":            true,
+		"yqfxRiskCounts":             true,
+		"yqfxRiskHighCounts":         true,
+		"yqfxRiskMiddleCounts":       true,
+		"zlfxpgRiskCounts":           true,
+		"zlfxpgRiskHighCounts":       true,
+		"zlfxpgRiskMiddleCounts":     true,
+		"jdpgRiskCounts":             true,
 		"jdpgRiskHighCounts":         true,
 		"jdpgRiskMiddleCounts":       true,
 		"idCardRiskCounts":           true,
@@ -1277,7 +1277,7 @@ func buildElementVerificationDetail(apiData map[string]interface{}, log *zap.Log
 					}
 				}
 			}
-			
+
 			if status != "" {
 				if status == "一致" {
 					detail["sfzeysFlag"] = 2 // 低风险
@@ -1313,7 +1313,7 @@ func buildElementVerificationDetail(apiData map[string]interface{}, log *zap.Log
 					}
 				}
 			}
-			
+
 			if status != "" {
 				personCheckDetails["result"] = status
 			}
@@ -1365,7 +1365,7 @@ func buildElementVerificationDetail(apiData map[string]interface{}, log *zap.Log
 				// 如果没有data字段，直接使用flxgMap（新格式）
 				data = flxgMap
 			}
-			
+
 			if moneyLaundering, ok := data["moneyLaundering"].(string); ok {
 				antiFraudInfo["moneyLaundering"] = moneyLaundering
 			}
@@ -1448,7 +1448,7 @@ func buildElementVerificationDetail(apiData map[string]interface{}, log *zap.Log
 				if channel, ok := yysy4b21Map["channel"].(string); ok {
 					phoneVailRisks["phoneCompany"] = convertChannelName(channel)
 				}
-				
+
 				// 获取在网时长（status=0时也要提取）
 				if yysy8b1cData != nil {
 					if yysy8b1cMap, ok := yysy8b1cData.(map[string]interface{}); ok {
@@ -1471,11 +1471,11 @@ func buildElementVerificationDetail(apiData map[string]interface{}, log *zap.Log
 	// 身份证号手机号归属地（belongRiskFlag 和 belongRisks）
 	belongRisks := make(map[string]interface{})
 	belongRisks["num"] = "1"
-	
+
 	// 重新获取数据
 	yysy9e4aDataForBelong := getMapValue(apiData, "YYSY9E4A")
 	yysyDataForBelong := getMapValue(apiData, "YYSYH6D2")
-	
+
 	if yysy9e4aDataForBelong != nil && yysyDataForBelong != nil {
 		if yysy9e4aMap, ok := yysy9e4aDataForBelong.(map[string]interface{}); ok {
 			if yysyMapForBelong, ok := yysyDataForBelong.(map[string]interface{}); ok {
@@ -1621,7 +1621,7 @@ func buildRiskSupervision(apiData map[string]interface{}, log *zap.Logger) map[s
 
 	// 从3C租赁申请意向获取数据
 	jrzq1d09Data := getMapValue(apiData, "JRZQ1D09")
-	
+
 	// 设置默认值
 	riskSupervision["rentalRiskListIdCardRelationsPhones"] = 0
 	riskSupervision["rentalRiskListPhoneRelationsIdCards"] = 0
@@ -1896,15 +1896,15 @@ func buildOverdueRiskProduct(apiData map[string]interface{}, log *zap.Logger) ma
 
 			// 判断风险标识
 			hasOverdue := overdueRiskProduct["hasUnsettledOverdue"] == "逾期"
-			hasRecentOverdue := overdueRiskProduct["overdueLast7Days"] == "逾期" || 
-				overdueRiskProduct["overdueLast14Days"] == "逾期" || 
+			hasRecentOverdue := overdueRiskProduct["overdueLast7Days"] == "逾期" ||
+				overdueRiskProduct["overdueLast14Days"] == "逾期" ||
 				overdueRiskProduct["overdueLast30Days"] == "逾期"
-			
+
 			if hasOverdue || hasRecentOverdue {
-				overdueRiskProduct["lyjlhyFlag"] = 1 // 高风险
+				overdueRiskProduct["lyjlhyFlag"] = 1  // 高风险
 				overdueRiskProduct["dkzhktjFlag"] = 1 // 高风险
 			} else {
-				overdueRiskProduct["lyjlhyFlag"] = 2 // 低风险
+				overdueRiskProduct["lyjlhyFlag"] = 2  // 低风险
 				overdueRiskProduct["dkzhktjFlag"] = 2 // 低风险
 			}
 		}
@@ -2028,7 +2028,7 @@ func buildMultCourtInfo(apiData map[string]interface{}, log *zap.Logger) map[str
 				if lawsuitStat, ok := judicialData["lawsuitStat"].(map[string]interface{}); ok {
 					// 收集所有涉案公告案件（民事、刑事、行政、保全、破产）- 都归到legalCases
 					legalCases := make([]interface{}, 0)
-					
+
 					// 处理民事案件（civil）- 结构：civil.cases[]
 					if civilVal, exists := lawsuitStat["civil"]; exists && civilVal != nil {
 						if civil, ok := civilVal.(map[string]interface{}); ok && len(civil) > 0 {
@@ -2178,7 +2178,7 @@ func buildMultCourtInfo(apiData map[string]interface{}, log *zap.Logger) map[str
 // convertCivilCase 转换民事案件
 func convertCivilCase(caseMap map[string]interface{}) map[string]interface{} {
 	caseInfo := make(map[string]interface{})
-	
+
 	// 案号
 	if cAh, ok := caseMap["c_ah"].(string); ok {
 		caseInfo["caseNumber"] = cAh
@@ -2259,7 +2259,7 @@ func convertCivilCase(caseMap map[string]interface{}) map[string]interface{} {
 // convertExecutionCase 转换执行案件
 func convertExecutionCase(caseMap map[string]interface{}) map[string]interface{} {
 	caseInfo := make(map[string]interface{})
-	
+
 	// 案号
 	if cAh, ok := caseMap["c_ah"].(string); ok {
 		caseInfo["caseNumber"] = cAh
@@ -2393,7 +2393,7 @@ func convertExecutionCase(caseMap map[string]interface{}) map[string]interface{}
 // convertBreachCase 转换失信案件
 func convertBreachCase(caseMap map[string]interface{}) map[string]interface{} {
 	caseInfo := make(map[string]interface{})
-	
+
 	// 案号
 	if caseNumber, ok := caseMap["caseNumber"].(string); ok {
 		caseInfo["caseNumber"] = caseNumber
@@ -2470,7 +2470,7 @@ func convertBreachCase(caseMap map[string]interface{}) map[string]interface{} {
 // convertLimitCase 转换限高案件
 func convertLimitCase(caseMap map[string]interface{}) map[string]interface{} {
 	caseInfo := make(map[string]interface{})
-	
+
 	// 案号
 	if caseNumber, ok := caseMap["caseNumber"].(string); ok {
 		caseInfo["caseNumber"] = caseNumber
@@ -2513,7 +2513,7 @@ func convertLimitCase(caseMap map[string]interface{}) map[string]interface{} {
 // convertPreservationCase 转换保全审查案件
 func convertPreservationCase(caseMap map[string]interface{}) map[string]interface{} {
 	caseInfo := make(map[string]interface{})
-	
+
 	// 案号
 	if cAh, ok := caseMap["c_ah"].(string); ok {
 		caseInfo["caseNumber"] = cAh
@@ -2607,7 +2607,7 @@ func convertPreservationCase(caseMap map[string]interface{}) map[string]interfac
 // convertCriminalCase 转换刑事案件
 func convertCriminalCase(caseMap map[string]interface{}) map[string]interface{} {
 	caseInfo := make(map[string]interface{})
-	
+
 	// 案号
 	if cAh, ok := caseMap["c_ah"].(string); ok {
 		caseInfo["caseNumber"] = cAh
@@ -2689,7 +2689,7 @@ func convertCriminalCase(caseMap map[string]interface{}) map[string]interface{}
 // convertAdministrativeCase 转换行政案件
 func convertAdministrativeCase(caseMap map[string]interface{}) map[string]interface{} {
 	caseInfo := make(map[string]interface{})
-	
+
 	// 案号
 	if cAh, ok := caseMap["c_ah"].(string); ok {
 		caseInfo["caseNumber"] = cAh
@@ -2772,7 +2772,7 @@ func convertAdministrativeCase(caseMap map[string]interface{}) map[string]interf
 // convertBankruptCase 转换破产清算案件
 func convertBankruptCase(caseMap map[string]interface{}) map[string]interface{} {
 	caseInfo := make(map[string]interface{})
-	
+
 	// 案号
 	if cAh, ok := caseMap["c_ah"].(string); ok {
 		caseInfo["caseNumber"] = cAh
@@ -2919,11 +2919,11 @@ func buildOrganLoanPerformances(variableValue map[string]interface{}) []interfac
 
 	// 时间周期映射
 	periodMap := map[string]string{
-		"last7Day":   "d7",
-		"last15Day":  "d15",
-		"last1Month": "m1",
-		"last3Month": "m3",
-		"last6Month": "m6",
+		"last7Day":    "d7",
+		"last15Day":   "d15",
+		"last1Month":  "m1",
+		"last3Month":  "m3",
+		"last6Month":  "m6",
 		"last12Month": "m12",
 	}
 
@@ -2983,11 +2983,11 @@ func buildCustomerLoanPerformances(variableValue map[string]interface{}) []inter
 	}
 
 	periodMap := map[string]string{
-		"last7Day":   "d7",
-		"last15Day":  "d15",
-		"last1Month": "m1",
-		"last3Month": "m3",
-		"last6Month": "m6",
+		"last7Day":    "d7",
+		"last15Day":   "d15",
+		"last1Month":  "m1",
+		"last3Month":  "m3",
+		"last6Month":  "m6",
 		"last12Month": "m12",
 	}
 
@@ -3001,7 +3001,7 @@ func buildCustomerLoanPerformances(variableValue map[string]interface{}) []inter
 			cellOrgnum := getStringValue(variableValue, fmt.Sprintf("als_%s_cell_%s_orgnum", apiPeriod, customerType.prefix))
 			idAllnum := getStringValue(variableValue, fmt.Sprintf("als_%s_id_%s_allnum", apiPeriod, customerType.prefix))
 			cellAllnum := getStringValue(variableValue, fmt.Sprintf("als_%s_cell_%s_allnum", apiPeriod, customerType.prefix))
-			
+
 			if idOrgnum == "" {
 				idOrgnum = "0"
 			}
@@ -3014,7 +3014,7 @@ func buildCustomerLoanPerformances(variableValue map[string]interface{}) []inter
 			if cellAllnum == "" {
 				cellAllnum = "0"
 			}
-			
+
 			perf[period] = fmt.Sprintf("%s/%s", idOrgnum, cellOrgnum)
 			perf[period+"Count"] = fmt.Sprintf("%s/%s", idAllnum, cellAllnum)
 		}
@@ -3043,11 +3043,11 @@ func buildBusinessLoanPerformances(variableValue map[string]interface{}) []inter
 	}
 
 	periodMap := map[string]string{
-		"last7Day":   "d7",
-		"last15Day":  "d15",
-		"last1Month": "m1",
-		"last3Month": "m3",
-		"last6Month": "m6",
+		"last7Day":    "d7",
+		"last15Day":   "d15",
+		"last1Month":  "m1",
+		"last3Month":  "m3",
+		"last6Month":  "m6",
 		"last12Month": "m12",
 	}
 
@@ -3061,7 +3061,7 @@ func buildBusinessLoanPerformances(variableValue map[string]interface{}) []inter
 			cellOrgnum := getStringValue(variableValue, fmt.Sprintf("als_%s_cell_%s_orgnum", apiPeriod, businessType.prefix))
 			idAllnum := getStringValue(variableValue, fmt.Sprintf("als_%s_id_%s_allnum", apiPeriod, businessType.prefix))
 			cellAllnum := getStringValue(variableValue, fmt.Sprintf("als_%s_cell_%s_allnum", apiPeriod, businessType.prefix))
-			
+
 			if idOrgnum == "" {
 				idOrgnum = "0"
 			}
@@ -3074,7 +3074,7 @@ func buildBusinessLoanPerformances(variableValue map[string]interface{}) []inter
 			if cellAllnum == "" {
 				cellAllnum = "0"
 			}
-			
+
 			perf[period] = fmt.Sprintf("%s/%s", idOrgnum, cellOrgnum)
 			perf[period+"Count"] = fmt.Sprintf("%s/%s", idAllnum, cellAllnum)
 		}
@@ -3102,11 +3102,11 @@ func buildTimeLoanPerformances(variableValue map[string]interface{}) []interface
 	}
 
 	periodMap := map[string]string{
-		"last7Day":   "d7",
-		"last15Day":  "d15",
-		"last1Month": "m1",
-		"last3Month": "m3",
-		"last6Month": "m6",
+		"last7Day":    "d7",
+		"last15Day":   "d15",
+		"last1Month":  "m1",
+		"last3Month":  "m3",
+		"last6Month":  "m6",
 		"last12Month": "m12",
 	}
 
@@ -3120,7 +3120,7 @@ func buildTimeLoanPerformances(variableValue map[string]interface{}) []interface
 			cellOrgnum := getStringValue(variableValue, fmt.Sprintf("als_%s_cell_%s_%s_orgnum", apiPeriod, timeType.orgType, timeType.timeType))
 			idAllnum := getStringValue(variableValue, fmt.Sprintf("als_%s_id_%s_%s_allnum", apiPeriod, timeType.orgType, timeType.timeType))
 			cellAllnum := getStringValue(variableValue, fmt.Sprintf("als_%s_cell_%s_%s_allnum", apiPeriod, timeType.orgType, timeType.timeType))
-			
+
 			if idOrgnum == "" {
 				idOrgnum = "0"
 			}
@@ -3133,7 +3133,7 @@ func buildTimeLoanPerformances(variableValue map[string]interface{}) []interface
 			if cellAllnum == "" {
 				cellAllnum = "0"
 			}
-			
+
 			perf[period] = fmt.Sprintf("%s/%s", idOrgnum, cellOrgnum)
 			perf[period+"Count"] = fmt.Sprintf("%s/%s", idAllnum, cellAllnum)
 		}
@@ -3151,7 +3151,7 @@ func checkLoanRisk(variableValue map[string]interface{}) bool {
 	for _, period := range periods {
 		bankAllnum := getStringValue(variableValue, fmt.Sprintf("als_%s_id_bank_allnum", period))
 		nbankAllnum := getStringValue(variableValue, fmt.Sprintf("als_%s_id_nbank_allnum", period))
-		
+
 		if bankAllnum != "" && bankAllnum != "0" {
 			if count, err := strconv.Atoi(bankAllnum); err == nil && count >= 10 {
 				return true
@@ -3593,7 +3593,7 @@ func checkRecentApplicationFrequency(variableValue map[string]interface{}, riskW
 	for _, period := range periods {
 		bankAllnum := getStringValue(variableValue, fmt.Sprintf("als_%s_id_bank_allnum", period.apiPeriod))
 		nbankAllnum := getStringValue(variableValue, fmt.Sprintf("als_%s_id_nbank_allnum", period.apiPeriod))
-		
+
 		// 如果近7天申请次数>=10，认为是极为频繁（调高风险阈值，进一步提高阈值）
 		if bankAllnum != "" && bankAllnum != "0" {
 			if count, err := strconv.Atoi(bankAllnum); err == nil && count >= 10 {
@@ -3626,7 +3626,7 @@ func checkBankApplicationFrequency(variableValue map[string]interface{}, riskWar
 	for _, period := range periods {
 		bankAllnum := getStringValue(variableValue, fmt.Sprintf("als_%s_id_bank_allnum", period.apiPeriod))
 		nbankAllnum := getStringValue(variableValue, fmt.Sprintf("als_%s_id_nbank_allnum", period.apiPeriod))
-		
+
 		if bankAllnum != "" && bankAllnum != "0" {
 			if count, err := strconv.Atoi(bankAllnum); err == nil {
 				bankTotal += count
@@ -3663,7 +3663,7 @@ func checkDebtPressure(apiData map[string]interface{}, riskWarning *map[string]i
 			// 检查当前逾期金额和机构数
 			currentOverdueAmount := getStringValue(jrzq5e9fMap, "xyp_cpl0072")
 			currentOverdueInstitutionCount := getStringValue(jrzq5e9fMap, "xyp_cpl0071")
-			
+
 			// 如果当前逾期金额较大或机构数较多，认为偿债压力极高
 			if currentOverdueAmount != "" && currentOverdueAmount != "0" && currentOverdueAmount != "1" {
 				(*riskWarning)["highDebtPressure"] = 1
@@ -3718,7 +3718,7 @@ func checkRentalApplicationFrequency(jrzq1d09Map map[string]interface{}, riskWar
 	for _, period := range periods {
 		idAllnum := getStringValue(jrzq1d09Map, fmt.Sprintf("alc_%s_id_allnum", period.apiPeriod))
 		cellAllnum := getStringValue(jrzq1d09Map, fmt.Sprintf("alc_%s_cell_allnum", period.apiPeriod))
-		
+
 		// 取较大的值
 		idCount := 0
 		cellCount := 0
@@ -3732,7 +3732,7 @@ func checkRentalApplicationFrequency(jrzq1d09Map map[string]interface{}, riskWar
 				cellCount = count
 			}
 		}
-		
+
 		if idCount > cellCount {
 			totalCount += idCount
 		} else {
@@ -3779,15 +3779,15 @@ func buildLeasingRiskAssessment(apiData map[string]interface{}, log *zap.Logger)
 			// - Institution（3C机构）: 使用id（身份证）查询的数据
 			// - Platform（3C平台）: 使用cell（手机号）查询的数据
 			// 格式： "身份证/手机号"，如果没有匹配的就是0
-			
+
 			// 时间周期映射：3Days->d3, 7Days->d7, 14Days->d14, Month->m1, 3Months->m3, 6Months->m6, 12Months->m12
 			periodMap := map[string]string{
-				"3Days":   "d3",
-				"7Days":   "d7",
-				"14Days":  "d14",
-				"Month":   "m1",
-				"3Months": "m3",
-				"6Months": "m6",
+				"3Days":    "d3",
+				"7Days":    "d7",
+				"14Days":   "d14",
+				"Month":    "m1",
+				"3Months":  "m3",
+				"6Months":  "m6",
 				"12Months": "m12",
 			}
 
@@ -4011,8 +4011,10 @@ func calculateAgeAndSex(idCard string) (int, string) {
 		return 0, ""
 	}
 
+	now := time.Now()
+
 	// 计算年龄（简化处理，使用当前年份）
-	age := 2024 - year
+	age := now.Year() - year
 
 	// 提取性别（第17位，奇数为男，偶数为女）
 	sexCode := idCard[16:17]
@@ -4050,21 +4052,21 @@ func normalizeProvinceName(province string) string {
 	if province == "" {
 		return ""
 	}
-	
+
 	// 去除前后空格
 	province = strings.TrimSpace(province)
-	
+
 	// 特殊处理：内蒙古（必须在最前面）
 	if strings.Contains(province, "内蒙古") {
 		return "内蒙古"
 	}
-	
+
 	// 处理自治区、特别行政区、直辖市等后缀
 	suffixes := []string{
 		"壮族自治区", "回族自治区", "维吾尔自治区", "自治区",
 		"特别行政区", "省", "市",
 	}
-	
+
 	normalized := province
 	for _, suffix := range suffixes {
 		if strings.HasSuffix(normalized, suffix) {
@@ -4072,7 +4074,7 @@ func normalizeProvinceName(province string) string {
 			break
 		}
 	}
-	
+
 	return normalized
 }
 
@@ -4082,15 +4084,15 @@ func normalizeCityName(city string) string {
 	if city == "" {
 		return ""
 	}
-	
+
 	// 去除前后空格
 	city = strings.TrimSpace(city)
-	
+
 	// 处理各种后缀
 	suffixes := []string{
 		"地区", "市", "自治州", "盟", "县", "区",
 	}
-	
+
 	normalized := city
 	for _, suffix := range suffixes {
 		if strings.HasSuffix(normalized, suffix) {
@@ -4098,7 +4100,7 @@ func normalizeCityName(city string) string {
 			break
 		}
 	}
-	
+
 	return normalized
 }
 
@@ -4107,12 +4109,12 @@ func extractProvinceFromAddress(address string) string {
 	if address == "" {
 		return ""
 	}
-	
+
 	// 特殊处理：内蒙古（必须在最前面，因为"内蒙古"可能被其他模式误匹配）
 	if strings.HasPrefix(address, "内蒙古") {
 		return "内蒙古自治区"
 	}
-	
+
 	// 处理直辖市（必须在自治区之前）
 	if strings.HasPrefix(address, "北京") {
 		return "北京市"
@@ -4126,7 +4128,7 @@ func extractProvinceFromAddress(address string) string {
 	if strings.HasPrefix(address, "重庆") {
 		return "重庆市"
 	}
-	
+
 	// 处理各种省份格式（按长度从长到短，避免误匹配）
 	patterns := []struct {
 		pattern string
@@ -4170,12 +4172,12 @@ func extractProvinceFromAddress(address string) string {
 		// 处理"XX省"格式（最后处理，因为可能与其他模式冲突）
 		{"省", func(addr string) string {
 			if idx := strings.Index(addr, "省"); idx > 0 {
-				return addr[:idx+1]
+				return addr[:idx+len("省")]
 			}
 			return ""
 		}},
 	}
-	
+
 	for _, p := range patterns {
 		if strings.Contains(address, p.pattern) {
 			if result := p.extract(address); result != "" {
@@ -4183,7 +4185,7 @@ func extractProvinceFromAddress(address string) string {
 			}
 		}
 	}
-	
+
 	return ""
 }
 
@@ -4192,16 +4194,16 @@ func extractCityFromAddress(address string) string {
 	if address == "" {
 		return ""
 	}
-	
+
 	// 先提取省份，然后从剩余部分提取城市
 	province := extractProvinceFromAddress(address)
 	if province == "" {
 		return ""
 	}
-	
+
 	// 去除省份部分
 	cityPart := address[len(province):]
-	
+
 	// 处理各种城市格式
 	patterns := []string{"地区", "市", "自治州", "盟"}
 	for _, pattern := range patterns {
@@ -4209,7 +4211,7 @@ func extractCityFromAddress(address string) string {
 			return cityPart[:idx+len(pattern)]
 		}
 	}
-	
+
 	return ""
 }
 
@@ -4221,7 +4223,7 @@ func compareLocation(address1, province2, city2 string) bool {
 	if address1 == "" {
 		return false
 	}
-	
+
 	// 如果号码归属地只有省份，检查省份是否出现在户籍所在地中
 	if province2 != "" && city2 == "" {
 		// 标准化省份名称，去除后缀
@@ -4229,20 +4231,20 @@ func compareLocation(address1, province2, city2 string) bool {
 		// 检查标准化后的省份名称是否出现在户籍所在地中
 		return strings.Contains(address1, province2Norm)
 	}
-	
+
 	// 如果号码归属地有省份和城市，检查两者是否都出现在户籍所在地中
 	if province2 != "" && city2 != "" {
 		// 标准化省份和城市名称，去除后缀
 		province2Norm := normalizeProvinceName(province2)
 		city2Norm := normalizeCityName(city2)
-		
+
 		// 检查省份和城市是否都出现在户籍所在地中
 		provinceMatch := strings.Contains(address1, province2Norm)
 		cityMatch := strings.Contains(address1, city2Norm)
-		
+
 		return provinceMatch && cityMatch
 	}
-	
+
 	return false
 }
 
@@ -4262,7 +4264,7 @@ func convertChannel(channel string) string {
 // convertChannelName 转换运营商名称（处理中文名称）
 func convertChannelName(channel string) string {
 	// 如果已经是中文名称，直接返回
-	if strings.Contains(channel, "移动") || strings.Contains(channel, "联通") || 
+	if strings.Contains(channel, "移动") || strings.Contains(channel, "联通") ||
 		strings.Contains(channel, "电信") || strings.Contains(channel, "广电") {
 		return channel
 	}
@@ -4276,7 +4278,7 @@ func convertStatusFromOnlineStatus(data map[string]interface{}) int {
 	// 获取status字段（0-在网，1-不在网）
 	var statusVal interface{}
 	var ok bool
-	
+
 	// status可能是int或float64类型
 	if statusVal, ok = data["status"]; !ok {
 		return -1 // 未查得
@@ -4362,7 +4364,7 @@ func getFraudScore(apiData map[string]interface{}) int {
 	// 从涉赌涉诈风险评估获取基础反欺诈评分
 	flxgData := getMapValue(apiData, "FLXG8B4D")
 	baseScore := -1
-	
+
 	if flxgData != nil {
 		flxgMap, ok := flxgData.(map[string]interface{})
 		if ok {
@@ -4505,7 +4507,7 @@ func getCreditScore(apiData map[string]interface{}) int {
 			return 900
 		}
 		parsed, err := strconv.ParseFloat(v, 64)
-	if err != nil {
+		if err != nil {
 			// 解析失败，返回900（默认信用较好）
 			return 900
 		}
@@ -4546,7 +4548,7 @@ func isDevelopmentMode() bool {
 	if useMock := os.Getenv("DWBG_USE_MOCK_DATA"); useMock != "" {
 		return useMock == "1" || useMock == "true" || useMock == "yes"
 	}
-	
+
 	env := os.Getenv("ENV")
 	if env == "" {
 		env = os.Getenv("CONFIG_ENV")
@@ -4554,12 +4556,12 @@ func isDevelopmentMode() bool {
 	if env == "" {
 		env = os.Getenv("APP_ENV")
 	}
-	
+
 	// 默认开发环境
 	if env == "" {
 		return true
 	}
-	
+
 	return env == "development"
 }
 
@@ -4571,32 +4573,32 @@ func loadMockAPIDataFromFile(log *zap.Logger) map[string]interface{} {
 		// 默认使用最新的导出文件
 		mockDataPath = "api_data_export/api_data_4522_20260214_152339.json"
 	}
-	
+
 	// 检查文件是否存在
 	if _, err := os.Stat(mockDataPath); os.IsNotExist(err) {
 		log.Warn("开发模式：模拟数据文件不存在", zap.String("path", mockDataPath))
 		return nil
 	}
-	
+
 	// 读取文件内容
 	fileData, err := os.ReadFile(mockDataPath)
 	if err != nil {
 		log.Warn("开发模式：读取模拟数据文件失败", zap.String("path", mockDataPath), zap.Error(err))
 		return nil
 	}
-	
+
 	// 解析JSON
 	var apiData map[string]interface{}
 	if err := json.Unmarshal(fileData, &apiData); err != nil {
 		log.Warn("开发模式：解析模拟数据JSON失败", zap.String("path", mockDataPath), zap.Error(err))
 		return nil
 	}
-	
-	log.Info("开发模式：成功加载模拟数据", 
+
+	log.Info("开发模式：成功加载模拟数据",
 		zap.String("path", mockDataPath),
 		zap.Int("api_count", len(apiData)),
 	)
-	
+
 	return apiData
 }
 

internal/domains/api/services/processors/dwbg/谛听报告_风险标识判断标准.md

@@ -1,219 +0,0 @@
-# 谛听多维报告（DWBG8B4D）风险标识判断标准
-
-本文档汇总 `dwbg8b4d_processor.go` 中所有风险标识（*Flag / riskFlag）的判定规则与数据来源，便于查阅和评审。
-
----
-
-## 一、elementVerificationDetail（要素核验产品）内风险标识
-
-### 1. sjsysFlag（手机三要素简版风险标识）
-
-| 取值 | 含义   | 判断条件 |
-|------|--------|----------|
-| 0    | 未查得 | 无 YYSYH6D2 数据或无法解析 |
-| 1    | 高风险 | YYSYH6D2.result ≠ "0"（身份证+手机号+姓名 不一致） |
-| 2    | 低风险 | YYSYH6D2.result == "0"（三要素一致） |
-
-**数据源**：YYSYH6D2（手机三要素简版）
-
----
-
-### 2. sfzeysFlag（身份证二要素风险标识）
-
-| 取值 | 含义   | 判断条件 |
-|------|--------|----------|
-| 0    | 未查得 | 无 IVYZ9K7F 数据或 status/desc/result 无法解析 |
-| 1    | 高风险 | 核验结果不为「一致」 |
-| 2    | 低风险 | 核验结果为「一致」 |
-
-**数据源**：IVYZ9K7F（身份证二要素）。status 来自 data.status、desc 或 result（0=一致，非0=不一致）。
-
----
-
-### 3. onlineRiskFlag（手机在网时长风险标识）
-
-| 取值 | 含义   | 判断条件 |
-|------|--------|----------|
-| 0    | 未查得 | 无 YYSY8B1C 数据或 inTime 为空 |
-| 1    | 高风险 | inTime == "0" 或 "3"（在网时长极短） |
-| 2    | 低风险 | inTime 为其他非空值 |
-
-**数据源**：YYSY8B1C（手机在网时长）
-
----
-
-### 4. phoneVailRiskFlag（手机信息验证风险标识）
-
-| 取值 | 含义   | 判断条件 |
-|------|--------|----------|
-| 0    | 未查得 | 无 YYSYE7V5 数据或 status 无法解析 |
-| 1    | 高风险 | status == 1（不在网） |
-| 2    | 低风险 | status == 0（在网/实号） |
-
-**数据源**：YYSYE7V5（手机在网状态等）
-
----
-
-### 5. belongRiskFlag（身份证号与手机号归属地风险标识）
-
-| 取值 | 含义   | 判断条件 |
-|------|--------|----------|
-| 0    | 未查得 | 无 YYSY9E4A 或 YYSYH6D2，或户籍/归属地任一方为空 |
-| 1    | 高风险 | 户籍所在地与号码归属地**不一致**（经智能比较） |
-| 2    | 低风险 | 户籍所在地与号码归属地**一致** |
-
-**数据源**：YYSY9E4A（号码归属地）、YYSYH6D2（address 作户籍）。使用 `compareLocation` 做省/市归一化后比较。
-
----
-
-### 6. highRiskFlag（公安重点人员核验风险标识）
-
-| 取值 | 含义   | 判断条件 |
-|------|--------|----------|
-| 0    | 无风险 | keyPersonCheckList 五项（fontFlag、jingJiFontFlag、fangAiFlag、zhongDianFlag、sheJiaoTongFlag）**均为 0** |
-| 1    | 高风险 | **任一项** fontFlag / jingJiFontFlag / fangAiFlag / zhongDianFlag 为 1（涉刑/经侦/妨害/重点/涉交通以外） |
-| 2    | 低风险 | **仅** sheJiaoTongFlag 为 1（仅涉交通命中），其余为 0 |
-
-**数据源**：FLXGDEA9 的 level 解析后填充 keyPersonCheckList（A→fontFlag, B→jingJiFontFlag, C→fangAiFlag, D→zhongDianFlag, E→sheJiaoTongFlag）。**不看是否有数据**，仅根据五项当前值判定。
-
----
-
-## 二、overdueRiskProduct（逾期风险产品）内风险标识
-
-### 7. lyjlhyFlag（履约/借贷逾期类风险标识）
-
-| 取值 | 含义   | 判断条件 |
-|------|--------|----------|
-| 0    | 未查得 | 无 JRZQ5E9F 数据（默认） |
-| 1    | 高风险 | 当前存在未结清逾期 **或** 近 7/14/30 天有逾期（hasUnsettledOverdue=="逾期" 或 overdueLast7Days/14Days/30Days 任一为「逾期」） |
-| 2    | 低风险 | 有 JRZQ5E9F 数据且无上述逾期情况 |
-
-**数据源**：JRZQ5E9F（借选指数评估），字段：xyp_cpl0044、xyp_cpl0029、xyp_cpl0030、xyp_cpl0031 等。
-
----
-
-### 8. dkzhktjFlag（贷款综合情况风险标识）
-
-与 **lyjlhyFlag** 使用同一套逻辑，同时赋值：有逾期或近期逾期则为 1，否则为 2。
-
-**数据源**：JRZQ5E9F。
-
----
-
-### 9. tsmdyzFlag（特殊名单验证风险标识）
-
-| 取值 | 含义   | 判断条件 |
-|------|--------|----------|
-| 0    | 未查得 | 无 JRZQ8A2D 数据（默认） |
-| 1    | 高风险 | specialListVerification 列表**非空**（身份证或手机号任一侧命中：法院失信人/被执行人、银行/非银中风险/一般风险/高风险等任一） |
-| 2    | 低风险 | 有 JRZQ8A2D 数据且 specialListVerification 为空 |
-
-**数据源**：JRZQ8A2D（特殊名单验证 B）。命中规则：id/cell 下对应字段值为 "0" 表示命中（如 court_bad、court_executed、bank_lost 等）。
-
----
-
-## 三、multCourtInfo（司法风险核验产品）内风险标识
-
-### 10. legalCasesFlag（涉案公告案件风险标识）
-
-| 取值 | 含义   | 判断条件 |
-|------|--------|----------|
-| 0    | 无     | 无 FLXG7E8F 或 lawsuitStat 下无民事/刑事/行政/保全/破产案件 |
-| 1    | 高风险 | legalCases 列表**非空**（民事、刑事、行政、保全、破产任一类 cases 非空） |
-
-**数据源**：FLXG7E8F（个人司法涉诉查询）→ judicial_data.lawsuitStat → civil/criminal/administrative/preservation/bankrupt.cases。
-
----
-
-### 11. executionCasesFlag（执行案件风险标识）
-
-| 取值 | 含义   | 判断条件 |
-|------|--------|----------|
-| 0    | 无     | 无 FLXG7E8F 或 implement.cases 为空 |
-| 1    | 高风险 | executionCases 列表**非空** |
-
-**数据源**：FLXG7E8F → judicial_data.lawsuitStat.implement.cases。
-
----
-
-### 12. disinCasesFlag（失信案件风险标识）
-
-| 取值 | 含义   | 判断条件 |
-|------|--------|----------|
-| 0    | 无     | 无 FLXG7E8F 或 breachCaseList 为空 |
-| 1    | 高风险 | disinCases 列表**非空** |
-
-**数据源**：FLXG7E8F → judicial_data.breachCaseList。
-
----
-
-### 13. limitCasesFlag（限高案件风险标识）
-
-| 取值 | 含义   | 判断条件 |
-|------|--------|----------|
-| 0    | 无     | 无 FLXG7E8F 或 consumptionRestrictionList 为空 |
-| 1    | 高风险 | limitCases 列表**非空** |
-
-**数据源**：FLXG7E8F → judicial_data.consumptionRestrictionList。
-
----
-
-## 四、loanEvaluationVerificationDetail（借贷评估产品）内风险标识
-
-### 14. riskFlag（借贷评估风险标识）
-
-| 取值 | 含义   | 判断条件 |
-|------|--------|----------|
-| 0    | 未查得 | 无 JRZQ6F2A 或 risk_screen_v2.variables[0].variableValue 无法解析 |
-| 1    | 高风险 | checkLoanRisk 为 true：**任一时间段**（d7/d15/m1/m3）下，银行或非银申请次数 **≥ 10**（als_{period}_id_bank_allnum / als_{period}_id_nbank_allnum） |
-| 2    | 低风险 | 有数据且 checkLoanRisk 为 false |
-
-**数据源**：JRZQ6F2A（借贷意向验证 A）→ risk_screen_v2.variables[0].variableValue。
-
----
-
-## 五、leasingRiskAssessment（租赁风险评估产品）内风险标识
-
-### 15. riskFlag（租赁风险评估标识）
-
-| 取值 | 含义   | 判断条件 |
-|------|--------|----------|
-| 0    | 无风险 | 近 12 月（m12）**总次数为 0**（身份证维度 alc_m12_id_allnum 与手机号维度 alc_m12_cell_allnum 取**较大值**后为 0） |
-| 1    | 高风险 | 近 12 月总次数 **> 10** |
-| 2    | 低风险 | 近 12 月总次数 **1～10**（含 10） |
-
-**数据源**：JRZQ1D09（3C 租赁申请意向）。**仅用近 12 月（Last12 / m12）**，totalCount = max(idCount, cellCount)。
-
----
-
-## 六、riskWarning（规则风险提示）内各项命中规则摘要
-
-以下为「命中即置 1」的规则，未命中或未查得均为 0。不改变上述各产品内 *Flag 的取值含义。
-
-| 类别           | 字段示例 | 命中条件（简要） |
-|----------------|----------|------------------|
-| 要素核查       | idCardTwoElementMismatch | IVYZ9K7F 二要素结果非「一致」 |
-|                | phoneThreeElementMismatch | YYSYH6D2.result ≠ "0" |
-| 运营商/在网     | shortPhoneDuration | YYSY8B1C.inTime == "0" |
-|                | shortPhoneDurationSlight | YYSY8B1C.inTime == "3" |
-|                | noPhoneDuration | YYSYE7V5.status==1 且 desc 含「风险」 |
-| 归属地         | idCardPhoneProvinceMismatch | 户籍与号码归属地智能比较不一致 |
-| 公安重点人员   | hasCriminalRecord / isEconomyFront / isDisrupSocial / isKeyPerson / isTrafficRelated | FLXGDEA9.level 解析后 A/B/C/D/E 前缀 |
-| 涉赌涉诈       | isAntiFraudInfo | FLXG8B4D 中 moneyLaundering/deceiver/gamblerPlayer/gamblerBanker 任一项非空且非"0" |
-| 逾期/名单      | hitHighRiskBankLastTwoYears / hitHighRiskNonBankLastTwoYears / hitCurrentOverdue | JRZQ8A2D.id 下 bank_lost/nbank_lost/bank_overdue/nbank_overdue 等字段值为 "0"（命中） |
-| 司法           | hitCivilCase / hitCriminalRisk / hitExecutionCase / hitAdministrativeCase / hitPreservationReview / hitBankruptcyAndLiquidation | FLXG7E8F 对应案件类型 **cases 数组非空**（不依 count） |
-| 借贷意向       | frequentApplicationRecent | 近 d7/d15/m1 银行或非银申请次数 **≥ 10**（JRZQ6F2A） |
-|                | frequentBankApplications / moreFrequentBankApplications | 近 m6+m12 银行申请总次数 **≥ 20** / **≥ 15** |
-|                | frequentNonBankApplications / moreFrequentNonBankApplications | 近 m6+m12 非银申请总次数 **≥ 20** / **≥ 15** |
-| 租赁申请       | veryFrequentRentalApplications / frequentRentalApplications | JRZQ1D09 近 m3+m6+m12（每期取 id/cell 较大值再累加）总次数 **≥ 20** / **≥ 15** |
-| 偿债压力       | highDebtPressure | JRZQ5E9F 当前逾期金额或当前逾期机构数非空且非 "0"/"1" |
-
----
-
-## 七、风险取值约定（通用）
-
-- **0**：未查得 / 无风险 / 无命中（依字段语义）
-- **1**：高风险 / 命中
-- **2**：低风险（仅部分 *Flag 使用，如 sjsysFlag、sfzeysFlag、onlineRiskFlag、phoneVailRiskFlag、belongRiskFlag、highRiskFlag、lyjlhyFlag、dkzhktjFlag、tsmdyzFlag、loanEvaluation riskFlag、leasingRiskAssessment riskFlag）
-
-文档版本：根据当前 `dwbg8b4d_processor.go` 逻辑整理，若有代码变更请同步更新本文档。

internal/domains/api/services/processors/ivyz/ivyzocr1_processor.go

@@ -0,0 +1,48 @@
+package ivyz
+
+import (
+	"context"
+	"encoding/json"
+	"errors"
+
+	"tyapi-server/internal/domains/api/dto"
+	"tyapi-server/internal/domains/api/services/processors"
+	"tyapi-server/internal/infrastructure/external/shujubao"
+)
+
+// ProcessIVYZOCR1Request IVYZOCR1 身份证OCR API 处理方法（使用数据宝服务示例）
+func ProcessIVYZOCR1Request(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) {
+	var paramsDto dto.IVYZOCR1Req
+	if err := json.Unmarshal(params, &paramsDto); err != nil {
+		return nil, errors.Join(processors.ErrSystem, err)
+	}
+
+	if err := deps.Validator.ValidateStruct(paramsDto); err != nil {
+		return nil, errors.Join(processors.ErrInvalidParam, err)
+	}
+
+	// 构建数据宝入参：姓名、身份证、手机号、银行卡号（sign 外的业务参数可按需 AES 加密后作为 bodyData）
+	reqParams := map[string]interface{}{
+		"key":     "8782f2a32463f75b53096323461df735",
+		"imageId": paramsDto.PhotoData,
+	}
+
+	// 最终请求 URL = https://api.chinadatapay.com/communication + 拼接接口地址值，如 personal/197
+	apiPath := "/trade/user/1985"
+	data, err := deps.ShujubaoService.CallAPI(ctx, apiPath, reqParams)
+	if err != nil {
+		if errors.Is(err, shujubao.ErrDatasource) {
+			return nil, errors.Join(processors.ErrDatasource, err)
+		}
+		if errors.Is(err, shujubao.ErrQueryEmpty) {
+			return nil, errors.Join(processors.ErrNotFound, err)
+		}
+		return nil, errors.Join(processors.ErrSystem, err)
+	}
+
+	respBytes, err := json.Marshal(data)
+	if err != nil {
+		return nil, errors.Join(processors.ErrSystem, err)
+	}
+	return respBytes, nil
+}

internal/domains/api/services/processors/ivyz/ivyzocr2_processor.go

@@ -0,0 +1,56 @@
+package ivyz
+
+import (
+	"context"
+	"encoding/json"
+	"errors"
+
+	"tyapi-server/internal/domains/api/dto"
+	"tyapi-server/internal/domains/api/services/processors"
+	"tyapi-server/internal/infrastructure/external/shumai"
+)
+
+// ProcessIVYZOCR2Request IVYZOCR2  OCR识别API处理方法数卖
+func ProcessIVYZOCR2Request(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) {
+	var paramsDto dto.IVYZOCR1Req
+	if err := json.Unmarshal(params, &paramsDto); err != nil {
+		return nil, errors.Join(processors.ErrSystem, err)
+	}
+
+	if err := deps.Validator.ValidateStruct(paramsDto); err != nil {
+		return nil, errors.Join(processors.ErrInvalidParam, err)
+	}
+
+	if paramsDto.PhotoData == "" && paramsDto.ImageUrl == "" {
+		return nil, errors.Join(processors.ErrInvalidParam, errors.New("photo_data or image_url is required"))
+	}
+
+	// 2选1：有值的用对应 key，空则用另一个
+	reqFormData := make(map[string]interface{})
+	if paramsDto.PhotoData != "" {
+		reqFormData["image"] = paramsDto.PhotoData
+	} else {
+		reqFormData["url"] = paramsDto.ImageUrl
+	}
+
+	// 以表单方式调用数脉 API；参数在 CallAPIForm 内转为 application/x-www-form-urlencoded
+	apiPath := "/v4/idcard/ocr" // 接口路径，根据数脉文档填写（如 v4/xxx）
+	respBytes, err := deps.ShumaiService.CallAPIForm(ctx, apiPath, reqFormData)
+	if err != nil {
+		if errors.Is(err, shumai.ErrNotFound) {
+			// 查无记录情况
+			return nil, errors.Join(processors.ErrNotFound, err)
+		} else if errors.Is(err, shumai.ErrDatasource) {
+			// 数据源错误
+			return nil, errors.Join(processors.ErrDatasource, err)
+		} else if errors.Is(err, shumai.ErrSystem) {
+			// 系统错误
+			return nil, errors.Join(processors.ErrSystem, err)
+		} else {
+			// 其他未知错误
+			return nil, errors.Join(processors.ErrSystem, err)
+		}
+	}
+
+	return respBytes, nil
+}

internal/domains/api/services/processors/jrzq/jrzqocre_processor.go

@@ -0,0 +1,52 @@
+package jrzq
+
+import (
+	"context"
+	"encoding/json"
+	"errors"
+
+	"tyapi-server/internal/domains/api/dto"
+	"tyapi-server/internal/domains/api/services/processors"
+	"tyapi-server/internal/infrastructure/external/shumai"
+)
+
+// ProcessJRZQOCREERequest JRZQOCRE 银行卡OCR API 数卖服务示例
+func ProcessJRZQOCREERequest(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) {
+	var paramsDto dto.JRZQOCREReq
+	if err := json.Unmarshal(params, &paramsDto); err != nil {
+		return nil, errors.Join(processors.ErrSystem, err)
+	}
+
+	if err := deps.Validator.ValidateStruct(paramsDto); err != nil {
+		return nil, errors.Join(processors.ErrInvalidParam, err)
+	}
+
+	if paramsDto.PhotoData == "" && paramsDto.ImageUrl == "" {
+		return nil, errors.Join(processors.ErrInvalidParam, errors.New("photo_data or image_url is required"))
+	}
+
+	// 2选1：有值的用对应 key，空则用另一个
+	reqFormData := make(map[string]interface{})
+	if paramsDto.PhotoData != "" {
+		reqFormData["image"] = paramsDto.PhotoData
+	} else {
+		reqFormData["url"] = paramsDto.ImageUrl
+	}
+	// 以表单方式调用数脉 API；参数在 CallAPIForm 内转为 application/x-www-form-urlencoded
+	apiPath := "/v2/bankcard/ocr" // 接口路径，根据数脉文档填写（如 v4/xxx）
+	respBytes, err := deps.ShumaiService.CallAPIForm(ctx, apiPath, reqFormData)
+	if err != nil {
+		if errors.Is(err, shumai.ErrDatasource) {
+			// 数据源错误
+			return nil, errors.Join(processors.ErrDatasource, err)
+		} else if errors.Is(err, shumai.ErrSystem) {
+			// 系统错误
+			return nil, errors.Join(processors.ErrSystem, err)
+		} else {
+			// 其他未知错误
+			return nil, errors.Join(processors.ErrSystem, err)
+		}
+	}
+
+	return respBytes, nil
+}

internal/domains/api/services/processors/jrzq/jrzqocry_processor.go

@@ -0,0 +1,48 @@
+package jrzq
+
+import (
+	"context"
+	"encoding/json"
+	"errors"
+
+	"tyapi-server/internal/domains/api/dto"
+	"tyapi-server/internal/domains/api/services/processors"
+	"tyapi-server/internal/infrastructure/external/shujubao"
+)
+
+// ProcessJRZQOCRYERequest JRZQOCRY 银行卡OCR API 处理方法（使用数据宝服务示例）
+func ProcessJRZQOCRYERequest(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) {
+	var paramsDto dto.JRZQOCRYReq
+	if err := json.Unmarshal(params, &paramsDto); err != nil {
+		return nil, errors.Join(processors.ErrSystem, err)
+	}
+
+	if err := deps.Validator.ValidateStruct(paramsDto); err != nil {
+		return nil, errors.Join(processors.ErrInvalidParam, err)
+	}
+
+	// 构建数据宝入参：姓名、身份证、手机号、银行卡号（sign 外的业务参数可按需 AES 加密后作为 bodyData）
+	reqParams := map[string]interface{}{
+		"key":     "3ee8e7a7a71870db2c0bf98e7e6b8b5c",
+		"imageId": paramsDto.PhotoData,
+	}
+
+	// 最终请求 URL = https://api.chinadatapay.com/communication + 拼接接口地址值，如 personal/197
+	apiPath := "/trade/user/1986"
+	data, err := deps.ShujubaoService.CallAPI(ctx, apiPath, reqParams)
+	if err != nil {
+		if errors.Is(err, shujubao.ErrDatasource) {
+			return nil, errors.Join(processors.ErrDatasource, err)
+		}
+		if errors.Is(err, shujubao.ErrQueryEmpty) {
+			return nil, errors.Join(processors.ErrNotFound, err)
+		}
+		return nil, errors.Join(processors.ErrSystem, err)
+	}
+
+	respBytes, err := json.Marshal(data)
+	if err != nil {
+		return nil, errors.Join(processors.ErrSystem, err)
+	}
+	return respBytes, nil
+}

internal/domains/api/services/processors/qygl/qygl5s1i_processor.go

@@ -21,20 +21,23 @@ func ProcessQYGL5S1IRequest(ctx context.Context, params []byte, deps *processors
 	if err := deps.Validator.ValidateStruct(paramsDto); err != nil {
 		return nil, errors.Join(processors.ErrInvalidParam, err)
 	}
-	if paramsDto.EntCode == "" && paramsDto.EntName == "" {
-		return nil, errors.Join(processors.ErrInvalidParam, errors.New("必须提供企业统一信用代码或企业名称中的一个"))
+
+	encryptedEntName, err := deps.ZhichaService.Encrypt(paramsDto.EntName)
+	if err != nil {
+		return nil, errors.Join(processors.ErrSystem, err)
+	}
+	encryptedEntCode, err := deps.ZhichaService.Encrypt(paramsDto.EntCode)
+	if err != nil {
+		return nil, errors.Join(processors.ErrSystem, err)
 	}
 
-	// 优先使用企业名称，否则使用统一信用代码
-	var enterpriseNo, enterpriseName string
+	// 按企业名称时传 enterpriseNo（加密名），按统一信用代码时传 enterpriseName（加密代码）
+	reqData := map[string]interface{}{}
 	if paramsDto.EntName != "" {
-		enterpriseName = paramsDto.EntName
-	} else {
-		enterpriseNo = paramsDto.EntCode
+		reqData["enterpriseName"] = encryptedEntName
 	}
-	reqData := map[string]interface{}{
-		"enterpriseNo":   enterpriseNo,
-		"enterpriseName": enterpriseName,
+	if paramsDto.EntCode != "" {
+		reqData["enterpriseNo"] = encryptedEntCode
 	}
 
 	respData, err := deps.ZhichaService.CallAPI(ctx, "ZCI088", reqData)

internal/domains/api/services/processors/qygl/qyglj0q1_processor.go

@@ -0,0 +1,65 @@
+package qygl
+
+import (
+	"context"
+	"encoding/json"
+	"errors"
+
+	"tyapi-server/internal/domains/api/dto"
+	"tyapi-server/internal/domains/api/services/processors"
+	"tyapi-server/internal/infrastructure/external/shujubao"
+)
+
+// ProcessQYGLJ0Q1Request QYGLJ0Q1 企业股权结构全景查询 API 处理方法（使用数据宝服务示例）
+func ProcessQYGLJ0Q1Request(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) {
+	var paramsDto dto.QYGLJ0Q1Req
+	if err := json.Unmarshal(params, &paramsDto); err != nil {
+		return nil, errors.Join(processors.ErrSystem, err)
+	}
+
+	if err := deps.Validator.ValidateStruct(paramsDto); err != nil {
+		return nil, errors.Join(processors.ErrInvalidParam, err)
+	}
+
+	// 二选一：企业名称(entName) 与 统一社会信用代码(creditCode) 必须且仅能传其一
+	hasEntName := paramsDto.EntName != ""
+	hasEntCode := paramsDto.EntCode != ""
+	if hasEntName == hasEntCode { // 两个都填或两个都未填
+		return nil, errors.Join(processors.ErrInvalidParam, errors.New("ent_name 与 ent_code 二选一，必须且仅能传其中一个"))
+	}
+
+	// 构建数据宝入参（sign 外的业务参数可按需 AES 加密后作为 bodyData）
+	reqParams := map[string]interface{}{
+		"key": "adac456f7b4ced764b606c8b07fed4d3",
+	}
+	if hasEntName {
+		reqParams["entName"] = paramsDto.EntName
+	} else {
+		reqParams["creditCode"] = paramsDto.EntCode
+	}
+
+	// 最终请求 URL = https://api.chinadatapay.com/communication + 拼接接口地址值，如 personal/197
+	apiPath := "/communication/personal/10216"
+	data, err := deps.ShujubaoService.CallAPI(ctx, apiPath, reqParams)
+	if err != nil {
+		if errors.Is(err, shujubao.ErrDatasource) {
+			return nil, errors.Join(processors.ErrDatasource, err)
+		}
+		if errors.Is(err, shujubao.ErrQueryEmpty) {
+			return nil, errors.Join(processors.ErrNotFound, err)
+		}
+		return nil, errors.Join(processors.ErrSystem, err)
+	}
+
+	// 解析响应中的 JSON 字符串（使用 qyglb4c0 中的 RecursiveParse）
+	parsedResp, err := RecursiveParse(data)
+	if err != nil {
+		return nil, errors.Join(processors.ErrSystem, err)
+	}
+
+	respBytes, err := json.Marshal(parsedResp)
+	if err != nil {
+		return nil, errors.Join(processors.ErrSystem, err)
+	}
+	return respBytes, nil
+}

internal/domains/api/services/processors/qygl/qygluy3s_processor.go

@@ -0,0 +1,56 @@
+package qygl
+
+import (
+	"context"
+	"encoding/json"
+	"errors"
+
+	"tyapi-server/internal/domains/api/dto"
+	"tyapi-server/internal/domains/api/services/processors"
+	"tyapi-server/internal/infrastructure/external/shujubao"
+)
+
+// ProcessQYGLUY3SRequest QYGLUY3S 企业全量信息核验V2 可用 API 处理方法（使用数据宝服务示例）
+func ProcessQYGLUY3SRequest(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) {
+	var paramsDto dto.QYGLUY3SReq
+	if err := json.Unmarshal(params, &paramsDto); err != nil {
+		return nil, errors.Join(processors.ErrSystem, err)
+	}
+
+	if err := deps.Validator.ValidateStruct(paramsDto); err != nil {
+		return nil, errors.Join(processors.ErrInvalidParam, err)
+	}
+
+	// 构建数据宝入参：姓名、身份证、手机号、银行卡号（sign 外的业务参数可按需 AES 加密后作为 bodyData）
+	reqParams := map[string]interface{}{
+		"key":        "5131227a847c06c111f624a22ebacc06",
+		"entName":    paramsDto.EntName,
+		"regno":      paramsDto.EntRegno,
+		"creditcode": paramsDto.EntCode,
+	}
+
+	// 最终请求 URL = https://api.chinadatapay.com/communication + 拼接接口地址值，如 personal/197
+	apiPath := "/communication/personal/10195"
+	data, err := deps.ShujubaoService.CallAPI(ctx, apiPath, reqParams)
+	if err != nil {
+		if errors.Is(err, shujubao.ErrDatasource) {
+			return nil, errors.Join(processors.ErrDatasource, err)
+		}
+		if errors.Is(err, shujubao.ErrQueryEmpty) {
+			return nil, errors.Join(processors.ErrNotFound, err)
+		}
+		return nil, errors.Join(processors.ErrSystem, err)
+	}
+
+	// 解析响应中的 JSON 字符串（使用 qyglb4c0 中的 RecursiveParse）
+	parsedResp, err := RecursiveParse(data)
+	if err != nil {
+		return nil, errors.Join(processors.ErrSystem, err)
+	}
+
+	respBytes, err := json.Marshal(parsedResp)
+	if err != nil {
+		return nil, errors.Join(processors.ErrSystem, err)
+	}
+	return respBytes, nil
+}

internal/domains/api/services/processors/yysy/yysy35ta_processor.go

@@ -0,0 +1,48 @@
+package yysy
+
+import (
+	"context"
+	"encoding/json"
+	"errors"
+
+	"tyapi-server/internal/domains/api/dto"
+	"tyapi-server/internal/domains/api/services/processors"
+	"tyapi-server/internal/infrastructure/external/shumai"
+)
+
+// ProcessYYSY35TARequest YYSY35TA  API 运营商归属地数卖处理方法数脉
+func ProcessYYSY35TARequest(ctx context.Context, params []byte, deps *processors.ProcessorDependencies) ([]byte, error) {
+	var paramsDto dto.YYSY35TAReq
+	if err := json.Unmarshal(params, &paramsDto); err != nil {
+		return nil, errors.Join(processors.ErrSystem, err)
+	}
+
+	if err := deps.Validator.ValidateStruct(paramsDto); err != nil {
+		return nil, errors.Join(processors.ErrInvalidParam, err)
+	}
+
+	reqFormData := map[string]interface{}{
+		"mobile": paramsDto.MobileNo,
+	}
+
+	// 以表单方式调用数脉 API；参数在 CallAPIForm 内转为 application/x-www-form-urlencoded
+	apiPath := "/v4/phone/number" // 接口路径，根据数脉文档填写（如 v4/xxx）
+	respBytes, err := deps.ShumaiService.CallAPIForm(ctx, apiPath, reqFormData)
+	if err != nil {
+		if errors.Is(err, shumai.ErrNotFound) {
+			// 查无记录情况
+			return nil, errors.Join(processors.ErrNotFound, err)
+		} else if errors.Is(err, shumai.ErrDatasource) {
+			// 数据源错误
+			return nil, errors.Join(processors.ErrDatasource, err)
+		} else if errors.Is(err, shumai.ErrSystem) {
+			// 系统错误
+			return nil, errors.Join(processors.ErrSystem, err)
+		} else {
+			// 其他未知错误
+			return nil, errors.Join(processors.ErrSystem, err)
+		}
+	}
+
+	return respBytes, nil
+}

internal/domains/api/services/processors/yysy/yysy9e4a_processor.go

@@ -39,6 +39,14 @@ func ProcessYYSY9E4ARequest(ctx context.Context, params []byte, deps *processors
 		}
 	}
 
+	// 兼容上游有时返回 JSON 字符串的情况：如果是字符串则尝试再反序列化一次
+	if str, ok := respData.(string); ok && str != "" {
+		var parsed interface{}
+		if err := json.Unmarshal([]byte(str), &parsed); err == nil {
+			respData = parsed
+		}
+	}
+
 	// 将响应数据转换为JSON字节
 	respBytes, err := json.Marshal(respData)
 	if err != nil {

internal/infrastructure/database/repositories/user/gorm_user_repository.go

@@ -20,7 +20,7 @@ import (
 )
 
 const (
-	UsersTable = "users"
+	UsersTable   = "users"
 	UserCacheTTL = 30 * 60 // 30分钟
 )
 
@@ -415,7 +415,7 @@ func (r *GormUserRepository) GetSystemUserStatsByDateRange(ctx context.Context,
 // GetSystemDailyUserStats 获取系统每日用户统计
 func (r *GormUserRepository) GetSystemDailyUserStats(ctx context.Context, startDate, endDate time.Time) ([]map[string]interface{}, error) {
 	var results []map[string]interface{}
-	
+
 	sql := `
 		SELECT 
 			DATE(created_at) as date,
@@ -426,19 +426,19 @@ func (r *GormUserRepository) GetSystemDailyUserStats(ctx context.Context, startD
 		GROUP BY DATE(created_at)
 		ORDER BY date ASC
 	`
-	
+
 	err := r.GetDB(ctx).Raw(sql, startDate.Format("2006-01-02"), endDate.Format("2006-01-02")).Scan(&results).Error
 	if err != nil {
 		return nil, err
 	}
-	
+
 	return results, nil
 }
 
 // GetSystemMonthlyUserStats 获取系统每月用户统计
 func (r *GormUserRepository) GetSystemMonthlyUserStats(ctx context.Context, startDate, endDate time.Time) ([]map[string]interface{}, error) {
 	var results []map[string]interface{}
-	
+
 	sql := `
 		SELECT 
 			TO_CHAR(created_at, 'YYYY-MM') as month,
@@ -449,19 +449,19 @@ func (r *GormUserRepository) GetSystemMonthlyUserStats(ctx context.Context, star
 		GROUP BY TO_CHAR(created_at, 'YYYY-MM')
 		ORDER BY month ASC
 	`
-	
+
 	err := r.GetDB(ctx).Raw(sql, startDate, endDate).Scan(&results).Error
 	if err != nil {
 		return nil, err
 	}
-	
+
 	return results, nil
 }
 
 // GetSystemDailyCertificationStats 获取系统每日认证用户统计（基于is_certified字段）
 func (r *GormUserRepository) GetSystemDailyCertificationStats(ctx context.Context, startDate, endDate time.Time) ([]map[string]interface{}, error) {
 	var results []map[string]interface{}
-	
+
 	sql := `
 		SELECT 
 			DATE(updated_at) as date,
@@ -473,19 +473,19 @@ func (r *GormUserRepository) GetSystemDailyCertificationStats(ctx context.Contex
 		GROUP BY DATE(updated_at)
 		ORDER BY date ASC
 	`
-	
+
 	err := r.GetDB(ctx).Raw(sql, startDate.Format("2006-01-02"), endDate.Format("2006-01-02")).Scan(&results).Error
 	if err != nil {
 		return nil, err
 	}
-	
+
 	return results, nil
 }
 
 // GetSystemMonthlyCertificationStats 获取系统每月认证用户统计（基于is_certified字段）
 func (r *GormUserRepository) GetSystemMonthlyCertificationStats(ctx context.Context, startDate, endDate time.Time) ([]map[string]interface{}, error) {
 	var results []map[string]interface{}
-	
+
 	sql := `
 		SELECT 
 			TO_CHAR(updated_at, 'YYYY-MM') as month,
@@ -497,12 +497,12 @@ func (r *GormUserRepository) GetSystemMonthlyCertificationStats(ctx context.Cont
 		GROUP BY TO_CHAR(updated_at, 'YYYY-MM')
 		ORDER BY month ASC
 	`
-	
+
 	err := r.GetDB(ctx).Raw(sql, startDate, endDate).Scan(&results).Error
 	if err != nil {
 		return nil, err
 	}
-	
+
 	return results, nil
 }
 
@@ -510,7 +510,7 @@ func (r *GormUserRepository) GetSystemMonthlyCertificationStats(ctx context.Cont
 func (r *GormUserRepository) GetUserCallRankingByCalls(ctx context.Context, period string, limit int) ([]map[string]interface{}, error) {
 	var sql string
 	var args []interface{}
-	
+
 	switch period {
 	case "today":
 		sql = `
@@ -565,13 +565,13 @@ func (r *GormUserRepository) GetUserCallRankingByCalls(ctx context.Context, peri
 	default:
 		return nil, fmt.Errorf("不支持的时间周期: %s", period)
 	}
-	
+
 	var results []map[string]interface{}
 	err := r.GetDB(ctx).Raw(sql, args...).Scan(&results).Error
 	if err != nil {
 		return nil, err
 	}
-	
+
 	return results, nil
 }
 
@@ -579,7 +579,7 @@ func (r *GormUserRepository) GetUserCallRankingByCalls(ctx context.Context, peri
 func (r *GormUserRepository) GetUserCallRankingByConsumption(ctx context.Context, period string, limit int) ([]map[string]interface{}, error) {
 	var sql string
 	var args []interface{}
-	
+
 	switch period {
 	case "today":
 		sql = `
@@ -634,13 +634,13 @@ func (r *GormUserRepository) GetUserCallRankingByConsumption(ctx context.Context
 	default:
 		return nil, fmt.Errorf("不支持的时间周期: %s", period)
 	}
-	
+
 	var results []map[string]interface{}
 	err := r.GetDB(ctx).Raw(sql, args...).Scan(&results).Error
 	if err != nil {
 		return nil, err
 	}
-	
+
 	return results, nil
 }
 
@@ -648,7 +648,7 @@ func (r *GormUserRepository) GetUserCallRankingByConsumption(ctx context.Context
 func (r *GormUserRepository) GetRechargeRanking(ctx context.Context, period string, limit int) ([]map[string]interface{}, error) {
 	var sql string
 	var args []interface{}
-	
+
 	switch period {
 	case "today":
 		sql = `
@@ -709,12 +709,12 @@ func (r *GormUserRepository) GetRechargeRanking(ctx context.Context, period stri
 	default:
 		return nil, fmt.Errorf("不支持的时间周期: %s", period)
 	}
-	
+
 	var results []map[string]interface{}
 	err := r.GetDB(ctx).Raw(sql, args...).Scan(&results).Error
 	if err != nil {
 		return nil, err
 	}
-	
+
 	return results, nil
-}
+}

internal/infrastructure/external/shujubao/shujubao_service.go

@@ -17,12 +17,50 @@ import (
 	"tyapi-server/internal/shared/external_logger"
 )
 
+const (
+	// 错误日志中单条入参值的最大长度，避免 base64 等长内容打满日志
+	maxLogParamValueLen = 300
+)
+
 var (
 	ErrDatasource = errors.New("数据源异常")
 	ErrSystem     = errors.New("系统异常")
 	ErrQueryEmpty = errors.New("查询为空")
 )
 
+// truncateForLog 将字符串截断到指定长度，用于错误日志，避免 base64 等过长内容
+func truncateForLog(s string, maxLen int) string {
+	if maxLen <= 0 {
+		return s
+	}
+	if len(s) <= maxLen {
+		return s
+	}
+	return s[:maxLen] + "...[truncated, total " + strconv.Itoa(len(s)) + " chars]"
+}
+
+// paramsForLog 返回适合写入错误日志的入参副本（长字符串会被截断）
+func paramsForLog(params map[string]interface{}) map[string]interface{} {
+	if params == nil {
+		return nil
+	}
+	out := make(map[string]interface{}, len(params))
+	for k, v := range params {
+		if v == nil {
+			out[k] = nil
+			continue
+		}
+		switch val := v.(type) {
+		case string:
+			out[k] = truncateForLog(val, maxLogParamValueLen)
+		default:
+			s := fmt.Sprint(v)
+			out[k] = truncateForLog(s, maxLogParamValueLen)
+		}
+	}
+	return out
+}
+
 // ShujubaoResp 数据宝 API 通用响应（按实际文档调整）
 type ShujubaoResp struct {
 	Code    string      `json:"code"`
@@ -187,7 +225,7 @@ func (s *ShujubaoService) CallAPI(ctx context.Context, apiPath string, params ma
 	if err != nil {
 		err = errors.Join(ErrSystem, err)
 		if s.logger != nil {
-			s.logger.LogError(requestID, transactionID, apiPath, err, params)
+			s.logger.LogError(requestID, transactionID, apiPath, err, paramsForLog(params))
 		}
 		return nil, err
 	}
@@ -216,7 +254,7 @@ func (s *ShujubaoService) CallAPI(ctx context.Context, apiPath string, params ma
 			err = errors.Join(ErrSystem, err)
 		}
 		if s.logger != nil {
-			s.logger.LogError(requestID, transactionID, apiPath, err, params)
+			s.logger.LogError(requestID, transactionID, apiPath, err, paramsForLog(params))
 		}
 		return nil, err
 	}
@@ -226,7 +264,7 @@ func (s *ShujubaoService) CallAPI(ctx context.Context, apiPath string, params ma
 	if err != nil {
 		err = errors.Join(ErrSystem, err)
 		if s.logger != nil {
-			s.logger.LogError(requestID, transactionID, apiPath, err, params)
+			s.logger.LogError(requestID, transactionID, apiPath, err, paramsForLog(params))
 		}
 		return nil, err
 	}
@@ -239,7 +277,7 @@ func (s *ShujubaoService) CallAPI(ctx context.Context, apiPath string, params ma
 	if response.StatusCode != http.StatusOK {
 		err = errors.Join(ErrDatasource, fmt.Errorf("HTTP状态码 %d", response.StatusCode))
 		if s.logger != nil {
-			s.logger.LogError(requestID, transactionID, apiPath, err, params)
+			s.logger.LogError(requestID, transactionID, apiPath, err, paramsForLog(params))
 		}
 		return nil, err
 	}
@@ -248,7 +286,7 @@ func (s *ShujubaoService) CallAPI(ctx context.Context, apiPath string, params ma
 	if err := json.Unmarshal(respBody, &shujubaoResp); err != nil {
 		err = errors.Join(ErrSystem, fmt.Errorf("响应解析失败: %w", err))
 		if s.logger != nil {
-			s.logger.LogError(requestID, transactionID, apiPath, err, params)
+			s.logger.LogError(requestID, transactionID, apiPath, err, paramsForLog(params))
 		}
 		return nil, err
 	}
@@ -261,7 +299,7 @@ func (s *ShujubaoService) CallAPI(ctx context.Context, apiPath string, params ma
 	if code != "10000" {
 		shujubaoErr := NewShujubaoErrorFromCode(code, shujubaoResp.Message)
 		if s.logger != nil {
-			s.logger.LogError(requestID, transactionID, apiPath, shujubaoErr, params)
+			s.logger.LogError(requestID, transactionID, apiPath, shujubaoErr, paramsForLog(params))
 		}
 		return nil, errors.Join(ErrDatasource, shujubaoErr)
 	}

internal/infrastructure/external/shumai/shumai_service.go

@@ -16,12 +16,52 @@ import (
 	"tyapi-server/internal/shared/external_logger"
 )
 
+const (
+	// 错误日志中单条入参值的最大长度，避免 base64 等长内容打满日志
+	maxLogParamValueLen = 300
+	// 错误日志中 response_body 的最大长度
+	maxLogResponseBodyLen = 500
+)
+
 var (
 	ErrDatasource = errors.New("数据源异常")
 	ErrSystem     = errors.New("系统异常")
 	ErrNotFound   = errors.New("查询为空")
 )
 
+// truncateForLog 将字符串截断到指定长度，用于错误日志，避免 base64 等过长内容
+func truncateForLog(s string, maxLen int) string {
+	if maxLen <= 0 {
+		return s
+	}
+	if len(s) <= maxLen {
+		return s
+	}
+	return s[:maxLen] + "...[truncated, total " + strconv.Itoa(len(s)) + " chars]"
+}
+
+// requestParamsForLog 返回适合写入错误日志的入参副本（长字符串会被截断）
+func requestParamsForLog(reqFormData map[string]interface{}) map[string]interface{} {
+	if reqFormData == nil {
+		return nil
+	}
+	out := make(map[string]interface{}, len(reqFormData))
+	for k, v := range reqFormData {
+		if v == nil {
+			out[k] = nil
+			continue
+		}
+		switch val := v.(type) {
+		case string:
+			out[k] = truncateForLog(val, maxLogParamValueLen)
+		default:
+			s := fmt.Sprint(v)
+			out[k] = truncateForLog(s, maxLogParamValueLen)
+		}
+	}
+	return out
+}
+
 // ShumaiResponse 数脉 API 通用响应（占位，按实际文档调整）
 type ShumaiResponse struct {
 	Code    int         `json:"code"` // 状态码
@@ -188,7 +228,7 @@ func (s *ShumaiService) CallAPIForm(ctx context.Context, apiPath string, reqForm
 	if err != nil {
 		err = errors.Join(ErrSystem, err)
 		if s.logger != nil {
-			s.logger.LogError(requestID, transactionID, apiPath, err, map[string]interface{}{"request_params": reqFormData})
+			s.logger.LogError(requestID, transactionID, apiPath, err, map[string]interface{}{"request_params": requestParamsForLog(reqFormData)})
 		}
 		return nil, err
 	}
@@ -216,7 +256,7 @@ func (s *ShumaiService) CallAPIForm(ctx context.Context, apiPath string, reqForm
 			err = errors.Join(ErrSystem, err)
 		}
 		if s.logger != nil {
-			s.logger.LogError(requestID, transactionID, apiPath, err, map[string]interface{}{"request_params": reqFormData})
+			s.logger.LogError(requestID, transactionID, apiPath, err, map[string]interface{}{"request_params": requestParamsForLog(reqFormData)})
 		}
 		return nil, err
 	}
@@ -227,7 +267,7 @@ func (s *ShumaiService) CallAPIForm(ctx context.Context, apiPath string, reqForm
 	if err != nil {
 		err = errors.Join(ErrSystem, err)
 		if s.logger != nil {
-			s.logger.LogError(requestID, transactionID, apiPath, err, map[string]interface{}{"request_params": reqFormData})
+			s.logger.LogError(requestID, transactionID, apiPath, err, map[string]interface{}{"request_params": requestParamsForLog(reqFormData)})
 		}
 		return nil, err
 	}
@@ -236,8 +276,8 @@ func (s *ShumaiService) CallAPIForm(ctx context.Context, apiPath string, reqForm
 		err = errors.Join(ErrDatasource, fmt.Errorf("HTTP %d", resp.StatusCode))
 		if s.logger != nil {
 			errorPayload := map[string]interface{}{
-				"request_params": reqFormData,
-				"response_body":  string(raw),
+				"request_params": requestParamsForLog(reqFormData),
+				"response_body":  truncateForLog(string(raw), maxLogResponseBodyLen),
 			}
 			s.logger.LogError(requestID, transactionID, apiPath, err, errorPayload)
 		}
@@ -253,8 +293,8 @@ func (s *ShumaiService) CallAPIForm(ctx context.Context, apiPath string, reqForm
 		parseErr := errors.Join(ErrSystem, fmt.Errorf("响应解析失败: %w", err))
 		if s.logger != nil {
 			s.logger.LogError(requestID, transactionID, apiPath, parseErr, map[string]interface{}{
-				"request_params": reqFormData,
-				"response_body":  string(raw),
+				"request_params": requestParamsForLog(reqFormData),
+				"response_body":  truncateForLog(string(raw), maxLogResponseBodyLen),
 			})
 		}
 		return nil, parseErr
@@ -273,8 +313,8 @@ func (s *ShumaiService) CallAPIForm(ctx context.Context, apiPath string, reqForm
 		}
 		if s.logger != nil {
 			s.logger.LogError(requestID, transactionID, apiPath, shumaiErr, map[string]interface{}{
-				"request_params": reqFormData,
-				"response_body":  string(raw),
+				"request_params": requestParamsForLog(reqFormData),
+				"response_body":  truncateForLog(string(raw), maxLogResponseBodyLen),
 			})
 		}
 		if shumaiErr.IsNoRecord() {
@@ -292,8 +332,8 @@ func (s *ShumaiService) CallAPIForm(ctx context.Context, apiPath string, reqForm
 		marshalErr := errors.Join(ErrSystem, fmt.Errorf("data 序列化失败: %w", err))
 		if s.logger != nil {
 			s.logger.LogError(requestID, transactionID, apiPath, marshalErr, map[string]interface{}{
-				"request_params": reqFormData,
-				"response_body":  string(raw),
+				"request_params": requestParamsForLog(reqFormData),
+				"response_body":  truncateForLog(string(raw), maxLogResponseBodyLen),
 			})
 		}
 		return nil, marshalErr

internal/infrastructure/external/zhicha/zhicha_service.go

@@ -210,8 +210,13 @@ func (z *ZhichaService) CallAPI(ctx context.Context, proID string, params map[st
 		return nil, ErrDatasource
 	}
 
-	// 201 表示查询为空，返回空对象
+	// 201 表示查询为空，兼容其它情况如果data也为空，则返回空对象
 	if zhichaResp.Code == "201" {
+		// 先做类型断言
+		dataMap, ok := zhichaResp.Data.(map[string]interface{})
+		if ok && len(dataMap) > 0 {
+			return dataMap, nil
+		}
 		return map[string]interface{}{}, nil
 	}