From 65bcd4bc1a3ea08d9a46637dcd2482fa3df6965d Mon Sep 17 00:00:00 2001 From: liangzai <2440983361@qq.com> Date: Mon, 29 Dec 2025 14:29:55 +0800 Subject: [PATCH] add JRZQ6F2A --- .../api/internal/service/apirequestService.go | 42 +++++++++++++++---- 1 file changed, 33 insertions(+), 9 deletions(-) diff --git a/app/main/api/internal/service/apirequestService.go b/app/main/api/internal/service/apirequestService.go index f7208cc..b69689c 100644 --- a/app/main/api/internal/service/apirequestService.go +++ b/app/main/api/internal/service/apirequestService.go @@ -61,23 +61,23 @@ type APIResponseData struct { func (a *ApiRequestService) ProcessRequests(params []byte, productID string) ([]byte, error) { var ctx, cancel = context.WithCancel(context.Background()) defer cancel() - build := a.productFeatureModel.SelectBuilder().Where(squirrel.Eq{ - "product_id": productID, - }) + build := a.productFeatureModel.SelectBuilder().Where(squirrel.Eq{ + "product_id": productID, + }) productFeatureList, findProductFeatureErr := a.productFeatureModel.FindAll(ctx, build, "") if findProductFeatureErr != nil { return nil, findProductFeatureErr } - var featureIDs []string - isImportantMap := make(map[string]int64, len(productFeatureList)) + var featureIDs []string + isImportantMap := make(map[string]int64, len(productFeatureList)) for _, pf := range productFeatureList { - featureIDs = append(featureIDs, pf.FeatureId) - isImportantMap[pf.FeatureId] = pf.IsImportant + featureIDs = append(featureIDs, pf.FeatureId) + isImportantMap[pf.FeatureId] = pf.IsImportant } if len(featureIDs) == 0 { return nil, errors.New("featureIDs 是空的") } - builder := a.featureModel.SelectBuilder().Where(squirrel.Eq{"id": featureIDs}) + builder := a.featureModel.SelectBuilder().Where(squirrel.Eq{"id": featureIDs}) featureList, findFeatureErr := a.featureModel.FindAll(ctx, builder, "") if findFeatureErr != nil { return nil, findFeatureErr @@ -114,7 +114,7 @@ func (a *ApiRequestService) ProcessRequests(params []byte, productID string) ([] preprocessErr error ) // 若 isImportantMap[feature.ID] == 1,则表示需要在出错时重试 - isImportant := isImportantMap[feature.Id] == 1 + isImportant := isImportantMap[feature.Id] == 1 tryCount := 0 for { tryCount++ @@ -207,6 +207,7 @@ var requestProcessors = map[string]func(*ApiRequestService, []byte) ([]byte, err "IVYZ8I9J": (*ApiRequestService).ProcessIVYZ8I9JRequest, "JRZQ7F1A": (*ApiRequestService).ProcessJRZQ7F1ARequest, "IVYZ3P9M": (*ApiRequestService).ProcessIVYZ3P9MRequest, + "JRZQ6F2A": (*ApiRequestService).ProcessJRZQ6F2ARequest, } // PreprocessRequestApi 调用指定的请求处理函数 @@ -1577,3 +1578,26 @@ func (a *ApiRequestService) ProcessIVYZ3P9MRequest(params []byte) ([]byte, error return convertTianyuanResponse(resp) } + +// ProcessJRZQ6F2ARequest 借贷申请 + +func (a *ApiRequestService) ProcessJRZQ6F2ARequest(params []byte) ([]byte, error) { + idCard := gjson.GetBytes(params, "id_card") + name := gjson.GetBytes(params, "name") + mobile := gjson.GetBytes(params, "mobile") + if !idCard.Exists() || !name.Exists() || !mobile.Exists() { + return nil, errors.New("api请求, JRZQ6F2A, 获取相关参数失败") + } + + resp, err := a.tianyuanapi.CallInterface("JRZQ6F2A", map[string]interface{}{ + "id_card": idCard.String(), + "name": name.String(), + "mobile_no": mobile.String(), + }) + + if err != nil { + return nil, err + } + + return convertTianyuanResponse(resp) +}