diff --git a/app/main/api/internal/service/apirequestService.go b/app/main/api/internal/service/apirequestService.go index 89aee64..4e7e32f 100644 --- a/app/main/api/internal/service/apirequestService.go +++ b/app/main/api/internal/service/apirequestService.go @@ -255,6 +255,7 @@ var requestProcessors = map[string]func(*ApiRequestService, context.Context, []b "IVYZ6G7H": (*ApiRequestService).ProcessIVYZ6G7HRequest, // 单人婚姻状态(补证版) "IVYZ3A7F": (*ApiRequestService).ProcessIVYZ3A7FRequest, // 学历信息查询(学校名称版) "YYSY7D3E": (*ApiRequestService).ProcessYYSY7D3ERequest, // 携号转网查询 + "IVYZ3P9M": (*ApiRequestService).ProcessIVYZ3P9MRequest, // 公安个人不良加强版 } // PreprocessRequestApi 调用指定的请求处理函数 @@ -2543,8 +2544,8 @@ func (a *ApiRequestService) ProcessFLXGDEA9Request(ctx context.Context, params [ return nil, errors.New("api请求, FLXGDEA9, 获取相关参数失败") } request := map[string]interface{}{ - "name": name.String(), - "id_card": idCard.String(), + "name": name.String(), + "id_card": idCard.String(), "authorized": "1", } resp, err := a.tianyuanapiService.CallInterface("FLXGDEA9", request) @@ -2650,3 +2651,28 @@ func (a *ApiRequestService) ProcessFLXG0687Request(params []byte) (*APIInternalR Data: jsonResult, }, nil } + +// ProcessIVYZ3P9MRequest 学历实时查询 +func (a *ApiRequestService) ProcessIVYZ3P9MRequest(ctx context.Context, params []byte) (*APIInternalResult, error) { + idCard := gjson.GetBytes(params, "id_card") + name := gjson.GetBytes(params, "name") + if !idCard.Exists() || !name.Exists() { + return nil, errors.New("api请求, IVYZ3P9M, 获取相关参数失败") + } + + resp, err := a.tianyuanapiService.CallInterface("IVYZ3P9M", map[string]interface{}{ + "id_card": idCard.String(), + "name": name.String(), + }) + if err != nil { + return nil, err + } + + jsonResult, err := json.Marshal(resp.Data) + if err != nil { + return nil, fmt.Errorf("处理反诈反赌核验查询结果失败: %v", err) + } + return &APIInternalResult{ + Data: jsonResult, + }, nil +}