diff --git a/app/main/api/internal/service/apirequestService.go b/app/main/api/internal/service/apirequestService.go index 771431b..8a5ac96 100644 --- a/app/main/api/internal/service/apirequestService.go +++ b/app/main/api/internal/service/apirequestService.go @@ -191,6 +191,7 @@ var requestProcessors = map[string]func(*ApiRequestService, []byte) ([]byte, err "JRZQ8203": (*ApiRequestService).ProcessJRZQ8203Request, "JRZQ4AA8": (*ApiRequestService).ProcessJRZQ4AA8Request, "QCXG7A2B": (*ApiRequestService).ProcessQCXG7A2BRequest, + "IVYZ81NC": (*ApiRequestService).ProcessIVYZ81NCRequest, } // PreprocessRequestApi 调用指定的请求处理函数 @@ -415,8 +416,8 @@ func (a *ApiRequestService) ProcessPersonEnterpriseProRequest(params []byte) ([] // 调用QYGL8271接口获取企业涉诉信息 lawsuitResp, err := a.tianyuanapi.CallInterface("QYGL8271", map[string]interface{}{ - "ent_name": orgName.String(), - "ent_code": creditCode.String(), + "ent_name": orgName.String(), + "ent_code": creditCode.String(), "auth_date": generateAuthDateRange(), }) // 无论是否有错误,都继续处理 @@ -986,8 +987,8 @@ func (a *ApiRequestService) ProcessQYGL8271Request(params []byte) ([]byte, error } resp, err := a.tianyuanapi.CallInterface("QYGL8271", map[string]interface{}{ - "ent_name": entName.String(), - "ent_code": entCode.String(), + "ent_name": entName.String(), + "ent_code": entCode.String(), "auth_date": generateAuthDateRange(), }) @@ -1236,3 +1237,24 @@ func (a *ApiRequestService) ProcessBehaviorRiskScanRequest(params []byte) ([]byt return finalResult, nil } + +// ProcessIVYZ81NCRequest 婚姻,登记时间版 +func (a *ApiRequestService) ProcessIVYZ81NCRequest(params []byte) ([]byte, error) { + name := gjson.GetBytes(params, "name") + idCard := gjson.GetBytes(params, "id_card") + if !name.Exists() || !idCard.Exists() { + return nil, errors.New("api请求, IVYZ81NC, 获取相关参数失败") + } + + resp, err := a.tianyuanapi.CallInterface("IVYZ81NC", map[string]interface{}{ + "name": name.String(), + "id_card": idCard.String(), + }) + + if err != nil { + return nil, err + } + + // 直接返回解密后的数据,而不是再次进行JSON编码 + return convertTianyuanResponse(resp) +}