diff --git a/app/user/cmd/api/internal/service/apirequestService.go b/app/user/cmd/api/internal/service/apirequestService.go index b6d4cbb..10a77e2 100644 --- a/app/user/cmd/api/internal/service/apirequestService.go +++ b/app/user/cmd/api/internal/service/apirequestService.go @@ -184,6 +184,7 @@ var requestProcessors = map[string]func(*ApiRequestService, []byte) ([]byte, err "P_C_B332": (*ApiRequestService).ProcessP_C_B332Request, "FIN019": (*ApiRequestService).ProcessFIN019Request, "CAR061": (*ApiRequestService).ProcessCAR061Request, + "IDV044": (*ApiRequestService).ProcessIDV044Request, "G10SC02": (*ApiRequestService).ProcessG10SC02Request, "G03HZ01": (*ApiRequestService).ProcessG03HZ01Request, "G02BJ02": (*ApiRequestService).ProcessG02BJ02Request, @@ -779,6 +780,23 @@ func (a *ApiRequestService) ProcessCAR061Request(params []byte) ([]byte, error) return resp, nil } +func (a *ApiRequestService) ProcessIDV044Request(params []byte) ([]byte, error) { + idCard := gjson.GetBytes(params, "id_card") + name := gjson.GetBytes(params, "name") + if !idCard.Exists() || !name.Exists() { + return nil, errors.New("api请求, IDV044, 获取相关参数失败") + } + request := map[string]interface{}{ + "cardNo": idCard.String(), + "name": name.String(), + } + resp, err := a.yushanService.request("IDV044", request) + if err != nil { + return nil, fmt.Errorf("婚姻状态查询失败: %v", err) + } + return resp, nil +} + func (a *ApiRequestService) ProcessG10SC02Request(params []byte) ([]byte, error) { // 提取男方和女方信息 nameMan := gjson.GetBytes(params, "nameMan")