diff --git a/app/main/api/internal/service/apirequestService.go b/app/main/api/internal/service/apirequestService.go index 5aa4b49..3f53dc1 100644 --- a/app/main/api/internal/service/apirequestService.go +++ b/app/main/api/internal/service/apirequestService.go @@ -196,6 +196,7 @@ var requestProcessors = map[string]func(*ApiRequestService, []byte) ([]byte, err "JRZQ4B6C": (*ApiRequestService).ProcessJRZQ4B6CRequest, "JRZQ09J8": (*ApiRequestService).ProcessJRZQ09J8Request, "JRZQ5E9F": (*ApiRequestService).ProcessJRZQ5E9FRequest, + "QYGL3F8E": (*ApiRequestService).ProcessQYGL3F8ERequest, } // PreprocessRequestApi 调用指定的请求处理函数 @@ -1308,6 +1309,7 @@ func (a *ApiRequestService) ProcessJRZQ4B6CRequest(params []byte) ([]byte, error "name": name.String(), "id_card": idCard.String(), "mobile_no": mobile.String(), + "authorized": "1", }) if err != nil { @@ -1377,6 +1379,33 @@ func (a *ApiRequestService) ProcessJRZQ5E9FRequest(params []byte) ([]byte, error return nil, err } + respBytes, err := convertTianyuanResponse(resp) + if err != nil { + return nil, err + } + // 重新编码为 JSON + data, err := json.Marshal(respBytes) + if err != nil { + return nil, fmt.Errorf("编码修改后的 data 失败: %v", err) + } + return data, nil +} + +// ProcessQYGL3F8ERequest 人企关系加强版2 +func (a *ApiRequestService) ProcessQYGL3F8ERequest(params []byte) ([]byte, error) { + idCard := gjson.GetBytes(params, "id_card") + if !idCard.Exists() { + return nil, errors.New("api请求, QYGL3F8E, 获取相关参数失败") + } + + resp, err := a.tianyuanapi.CallInterface("QYGL3F8E", map[string]interface{}{ + "id_card": idCard.String(), + }) + + if err != nil { + return nil, err + } + respBytes, err := convertTianyuanResponse(resp) if err != nil { return nil, err