diff --git a/app/main/api/internal/service/apirequestService.go b/app/main/api/internal/service/apirequestService.go index e739d39..333feb8 100644 --- a/app/main/api/internal/service/apirequestService.go +++ b/app/main/api/internal/service/apirequestService.go @@ -197,6 +197,7 @@ var requestProcessors = map[string]func(*ApiRequestService, []byte) ([]byte, err "JRZQ09J8": (*ApiRequestService).ProcessJRZQ09J8Request, "JRZQ5E9F": (*ApiRequestService).ProcessJRZQ5E9FRequest, "QYGL3F8E": (*ApiRequestService).ProcessQYGL3F8ERequest, + "IVYZ81NC": (*ApiRequestService).ProcessIVYZ81NCRequest, } // PreprocessRequestApi 调用指定的请求处理函数 @@ -421,8 +422,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(), }) // 无论是否有错误,都继续处理 @@ -547,7 +548,7 @@ func (a *ApiRequestService) ProcessPersonEnterpriseProRequest(params []byte) ([] func (a *ApiRequestService) ProcesFLXG0V4BRequest(params []byte) ([]byte, error) { name := gjson.GetBytes(params, "name") idCard := gjson.GetBytes(params, "id_card") - if !name.Exists() || !idCard.Exists(){ + if !name.Exists() || !idCard.Exists() { return nil, errors.New("api请求, FLXG0V4B, 获取相关参数失败") } @@ -565,6 +566,7 @@ func (a *ApiRequestService) ProcesFLXG0V4BRequest(params []byte) ([]byte, error) } return respBytes, nil } + // ProcessFLXG0687Request 反诈反赌核验 func (a *ApiRequestService) ProcessFLXG0687Request(params []byte) ([]byte, error) { idCard := gjson.GetBytes(params, "id_card") @@ -1230,6 +1232,7 @@ func (a *ApiRequestService) ProcessBehaviorRiskScanRequest(params []byte) ([]byt return finalResult, nil } + // ProcessDWBG8B4DRequest 谛听多维报告 func (a *ApiRequestService) ProcessDWBG8B4DRequest(params []byte) ([]byte, error) { name := gjson.GetBytes(params, "name") @@ -1241,9 +1244,9 @@ func (a *ApiRequestService) ProcessDWBG8B4DRequest(params []byte) ([]byte, error } resp, err := a.tianyuanapi.CallInterface("DWBG8B4D", map[string]interface{}{ - "name": name.String(), - "id_card": idCard.String(), - "mobile_no": mobile.String(), + "name": name.String(), + "id_card": idCard.String(), + "mobile_no": mobile.String(), "authorization_url": AuthorizationURL.String(), }) @@ -1266,9 +1269,9 @@ func (a *ApiRequestService) ProcessDWBG6A2CRequest(params []byte) ([]byte, error } resp, err := a.tianyuanapi.CallInterface("DWBG6A2C", map[string]interface{}{ - "name": name.String(), - "id_card": idCard.String(), - "mobile_no": mobile.String(), + "name": name.String(), + "id_card": idCard.String(), + "mobile_no": mobile.String(), "authorization_url": AuthorizationURL.String(), }) @@ -1290,9 +1293,9 @@ func (a *ApiRequestService) ProcessJRZQ4B6CRequest(params []byte) ([]byte, error } resp, err := a.tianyuanapi.CallInterface("JRZQ4B6C", map[string]interface{}{ - "name": name.String(), - "id_card": idCard.String(), - "mobile_no": mobile.String(), + "name": name.String(), + "id_card": idCard.String(), + "mobile_no": mobile.String(), "authorized": "1", }) @@ -1314,9 +1317,9 @@ func (a *ApiRequestService) ProcessJRZQ09J8Request(params []byte) ([]byte, error } resp, err := a.tianyuanapi.CallInterface("JRZQ09J8", map[string]interface{}{ - "name": name.String(), - "id_card": idCard.String(), - "mobile_no": mobile.String(), + "name": name.String(), + "id_card": idCard.String(), + "mobile_no": mobile.String(), "authorized": "1", }) @@ -1338,9 +1341,9 @@ func (a *ApiRequestService) ProcessJRZQ5E9FRequest(params []byte) ([]byte, error } resp, err := a.tianyuanapi.CallInterface("JRZQ5E9F", map[string]interface{}{ - "name": name.String(), - "id_card": idCard.String(), - "mobile_no": mobile.String(), + "name": name.String(), + "id_card": idCard.String(), + "mobile_no": mobile.String(), "authorized": "1", }) @@ -1360,7 +1363,7 @@ func (a *ApiRequestService) ProcessQYGL3F8ERequest(params []byte) ([]byte, error } resp, err := a.tianyuanapi.CallInterface("QYGL3F8E", map[string]interface{}{ - "id_card": idCard.String(), + "id_card": idCard.String(), }) if err != nil { @@ -1369,4 +1372,25 @@ func (a *ApiRequestService) ProcessQYGL3F8ERequest(params []byte) ([]byte, error // 直接返回解密后的数据,而不是再次进行JSON编码 return convertTianyuanResponse(resp) -} \ No newline at end of file +} + +// 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) +}