team/hm-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add IVYZ81NC

Browse Source
This commit is contained in:
liangzai
2025-10-18 14:36:45 +08:00
parent de519d073b
commit a2ef7bc093
1 changed files with 44 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

64
app/main/api/internal/service/apirequestService.go
View File

@@ -197,6 +197,7 @@ var requestProcessors = map[string]func(*ApiRequestService, []byte) ([]byte, err
"JRZQ09J8": (*ApiRequestService).ProcessJRZQ09J8Request, "JRZQ09J8": (*ApiRequestService).ProcessJRZQ09J8Request,
"JRZQ5E9F": (*ApiRequestService).ProcessJRZQ5E9FRequest, "JRZQ5E9F": (*ApiRequestService).ProcessJRZQ5E9FRequest,
"QYGL3F8E": (*ApiRequestService).ProcessQYGL3F8ERequest, "QYGL3F8E": (*ApiRequestService).ProcessQYGL3F8ERequest,
"IVYZ81NC": (*ApiRequestService).ProcessIVYZ81NCRequest,
} }
// PreprocessRequestApi 调用指定的请求处理函数 // PreprocessRequestApi 调用指定的请求处理函数
@@ -421,8 +422,8 @@ func (a *ApiRequestService) ProcessPersonEnterpriseProRequest(params []byte) ([]
// 调用QYGL8271接口获取企业涉诉信息 // 调用QYGL8271接口获取企业涉诉信息
lawsuitResp, err := a.tianyuanapi.CallInterface("QYGL8271", map[string]interface{}{ lawsuitResp, err := a.tianyuanapi.CallInterface("QYGL8271", map[string]interface{}{
"ent_name": orgName.String(), "ent_name": orgName.String(),
"ent_code": creditCode.String(), "ent_code": creditCode.String(),
"auth_date": generateAuthDateRange(), "auth_date": generateAuthDateRange(),
}) })
// 无论是否有错误，都继续处理 // 无论是否有错误，都继续处理
@@ -547,7 +548,7 @@ func (a *ApiRequestService) ProcessPersonEnterpriseProRequest(params []byte) ([]
func (a *ApiRequestService) ProcesFLXG0V4BRequest(params []byte) ([]byte, error) { func (a *ApiRequestService) ProcesFLXG0V4BRequest(params []byte) ([]byte, error) {
name := gjson.GetBytes(params, "name") name := gjson.GetBytes(params, "name")
idCard := gjson.GetBytes(params, "id_card") idCard := gjson.GetBytes(params, "id_card")
if !name.Exists() || !idCard.Exists(){ if !name.Exists() || !idCard.Exists() {
return nil, errors.New("api请求, FLXG0V4B, 获取相关参数失败") return nil, errors.New("api请求, FLXG0V4B, 获取相关参数失败")
} }
@@ -565,6 +566,7 @@ func (a *ApiRequestService) ProcesFLXG0V4BRequest(params []byte) ([]byte, error)
} }
return respBytes, nil return respBytes, nil
} }
// ProcessFLXG0687Request 反诈反赌核验 // ProcessFLXG0687Request 反诈反赌核验
func (a *ApiRequestService) ProcessFLXG0687Request(params []byte) ([]byte, error) { func (a *ApiRequestService) ProcessFLXG0687Request(params []byte) ([]byte, error) {
idCard := gjson.GetBytes(params, "id_card") idCard := gjson.GetBytes(params, "id_card")
@@ -1230,6 +1232,7 @@ func (a *ApiRequestService) ProcessBehaviorRiskScanRequest(params []byte) ([]byt
return finalResult, nil return finalResult, nil
} }
// ProcessDWBG8B4DRequest 谛听多维报告 // ProcessDWBG8B4DRequest 谛听多维报告
func (a *ApiRequestService) ProcessDWBG8B4DRequest(params []byte) ([]byte, error) { func (a *ApiRequestService) ProcessDWBG8B4DRequest(params []byte) ([]byte, error) {
name := gjson.GetBytes(params, "name") 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{}{ resp, err := a.tianyuanapi.CallInterface("DWBG8B4D", map[string]interface{}{
"name": name.String(), "name": name.String(),
"id_card": idCard.String(), "id_card": idCard.String(),
"mobile_no": mobile.String(), "mobile_no": mobile.String(),
"authorization_url": AuthorizationURL.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{}{ resp, err := a.tianyuanapi.CallInterface("DWBG6A2C", map[string]interface{}{
"name": name.String(), "name": name.String(),
"id_card": idCard.String(), "id_card": idCard.String(),
"mobile_no": mobile.String(), "mobile_no": mobile.String(),
"authorization_url": AuthorizationURL.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{}{ resp, err := a.tianyuanapi.CallInterface("JRZQ4B6C", map[string]interface{}{
"name": name.String(), "name": name.String(),
"id_card": idCard.String(), "id_card": idCard.String(),
"mobile_no": mobile.String(), "mobile_no": mobile.String(),
"authorized": "1", "authorized": "1",
}) })
@@ -1314,9 +1317,9 @@ func (a *ApiRequestService) ProcessJRZQ09J8Request(params []byte) ([]byte, error
} }
resp, err := a.tianyuanapi.CallInterface("JRZQ09J8", map[string]interface{}{ resp, err := a.tianyuanapi.CallInterface("JRZQ09J8", map[string]interface{}{
"name": name.String(), "name": name.String(),
"id_card": idCard.String(), "id_card": idCard.String(),
"mobile_no": mobile.String(), "mobile_no": mobile.String(),
"authorized": "1", "authorized": "1",
}) })
@@ -1338,9 +1341,9 @@ func (a *ApiRequestService) ProcessJRZQ5E9FRequest(params []byte) ([]byte, error
} }
resp, err := a.tianyuanapi.CallInterface("JRZQ5E9F", map[string]interface{}{ resp, err := a.tianyuanapi.CallInterface("JRZQ5E9F", map[string]interface{}{
"name": name.String(), "name": name.String(),
"id_card": idCard.String(), "id_card": idCard.String(),
"mobile_no": mobile.String(), "mobile_no": mobile.String(),
"authorized": "1", "authorized": "1",
}) })
@@ -1360,7 +1363,7 @@ func (a *ApiRequestService) ProcessQYGL3F8ERequest(params []byte) ([]byte, error
} }
resp, err := a.tianyuanapi.CallInterface("QYGL3F8E", map[string]interface{}{ resp, err := a.tianyuanapi.CallInterface("QYGL3F8E", map[string]interface{}{
"id_card": idCard.String(), "id_card": idCard.String(),
}) })
if err != nil { if err != nil {
@@ -1369,4 +1372,25 @@ func (a *ApiRequestService) ProcessQYGL3F8ERequest(params []byte) ([]byte, error
// 直接返回解密后的数据，而不是再次进行JSON编码 // 直接返回解密后的数据，而不是再次进行JSON编码
return convertTianyuanResponse(resp) return convertTianyuanResponse(resp)
} }
// 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)
}