From b0d13d3642761856c2111c08b08f861be199f206 Mon Sep 17 00:00:00 2001 From: liangzai <2440983361@qq.com> Date: Wed, 6 Nov 2024 17:10:34 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E4=B8=AA=E4=BA=BA=E4=B8=8D?= =?UTF-8?q?=E8=89=AF=E6=A0=87=E5=87=86=E7=89=88FLXG0V3B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- apps/api/api.api | 3 + .../internal/handler/FLXG/flxg0v3bhandler.go | 29 +++++ .../internal/handler/FLXG/flxg3d56handler.go | 1 - apps/api/internal/handler/routes.go | 5 + apps/api/internal/logic/FLXG/flxg0v3blogic.go | 111 ++++++++++++++++++ apps/api/internal/validator/structs.go | 4 + apps/api/internal/westmodel/fieldMapping.go | 4 + 7 files changed, 156 insertions(+), 1 deletion(-) create mode 100644 apps/api/internal/handler/FLXG/flxg0v3bhandler.go create mode 100644 apps/api/internal/logic/FLXG/flxg0v3blogic.go diff --git a/apps/api/api.api b/apps/api/api.api index e74fb6c..d8d28c9 100644 --- a/apps/api/api.api +++ b/apps/api/api.api @@ -71,6 +71,9 @@ service api-api { @handler FLXG3D56 post /FLXG3D56 (request) returns (string) + + @handler FLXG0V3B + post /FLXG0V3B (request) returns (string) } @server ( diff --git a/apps/api/internal/handler/FLXG/flxg0v3bhandler.go b/apps/api/internal/handler/FLXG/flxg0v3bhandler.go new file mode 100644 index 0000000..ca7077c --- /dev/null +++ b/apps/api/internal/handler/FLXG/flxg0v3bhandler.go @@ -0,0 +1,29 @@ +package FLXG + +import ( + "net/http" + "tianyuan-api/pkg/errs" + "tianyuan-api/pkg/response" + + "github.com/zeromicro/go-zero/rest/httpx" + "tianyuan-api/apps/api/internal/logic/FLXG" + "tianyuan-api/apps/api/internal/svc" + "tianyuan-api/apps/api/internal/types" +) + +func FLXG0V3BHandler(svcCtx *svc.ServiceContext) http.HandlerFunc { + return func(w http.ResponseWriter, r *http.Request) { + var req types.Request + if err := httpx.Parse(r, &req); err != nil { + response.Fail(r.Context(), w, errs.ErrParamValidation, nil) + return + } + l := FLXG.NewFLXG0V3BLogic(r.Context(), svcCtx) + resp, err := l.FLXG0V3B(&req) + if err != nil { + response.Fail(r.Context(), w, err, resp) + } else { + response.Success(r.Context(), w, resp) + } + } +} diff --git a/apps/api/internal/handler/FLXG/flxg3d56handler.go b/apps/api/internal/handler/FLXG/flxg3d56handler.go index 4d13db6..528eeb7 100644 --- a/apps/api/internal/handler/FLXG/flxg3d56handler.go +++ b/apps/api/internal/handler/FLXG/flxg3d56handler.go @@ -18,7 +18,6 @@ func FLXG3D56Handler(svcCtx *svc.ServiceContext) http.HandlerFunc { response.Fail(r.Context(), w, errs.ErrParamValidation, nil) return } - l := FLXG.NewFLXG3D56Logic(r.Context(), svcCtx) resp, err := l.FLXG3D56(&req) if err != nil { diff --git a/apps/api/internal/handler/routes.go b/apps/api/internal/handler/routes.go index 75b9c36..249fc8a 100644 --- a/apps/api/internal/handler/routes.go +++ b/apps/api/internal/handler/routes.go @@ -21,6 +21,11 @@ func RegisterHandlers(server *rest.Server, serverCtx *svc.ServiceContext) { rest.WithMiddlewares( []rest.Middleware{serverCtx.ApiAuthInterceptor}, []rest.Route{ + { + Method: http.MethodPost, + Path: "/FLXG0V3B", + Handler: FLXG.FLXG0V3BHandler(serverCtx), + }, { Method: http.MethodPost, Path: "/FLXG162A", diff --git a/apps/api/internal/logic/FLXG/flxg0v3blogic.go b/apps/api/internal/logic/FLXG/flxg0v3blogic.go new file mode 100644 index 0000000..13e55a0 --- /dev/null +++ b/apps/api/internal/logic/FLXG/flxg0v3blogic.go @@ -0,0 +1,111 @@ +package FLXG + +import ( + "context" + "encoding/hex" + "tianyuan-api/apps/api/internal/common" + "tianyuan-api/apps/api/internal/validator" + "tianyuan-api/apps/api/internal/westmodel" + "tianyuan-api/pkg/crypto" + "tianyuan-api/pkg/errs" + + "tianyuan-api/apps/api/internal/svc" + "tianyuan-api/apps/api/internal/types" + + "github.com/zeromicro/go-zero/core/logx" +) + +type FLXG0V3BLogic struct { + logx.Logger + ctx context.Context + svcCtx *svc.ServiceContext +} + +func NewFLXG0V3BLogic(ctx context.Context, svcCtx *svc.ServiceContext) *FLXG0V3BLogic { + return &FLXG0V3BLogic{ + Logger: logx.WithContext(ctx), + ctx: ctx, + svcCtx: svcCtx, + } +} + +func (l *FLXG0V3BLogic) FLXG0V3B(req *types.Request) (resp string, err *errs.AppError) { + var status string + var charges bool + var remark = "" + secretKey, ok := l.ctx.Value("secretKey").(string) + if !ok { + return "", errs.ErrSystem + } + transactionID, ok := l.ctx.Value("transactionID").(string) + if !ok { + return "", errs.ErrSystem + } + userId, userIdOk := l.ctx.Value("userId").(int64) + if !userIdOk { + return "", errs.ErrSystem + } + productCode, productCodeOk := l.ctx.Value("productCode").(string) + if !productCodeOk || productCode == "" { + return "", errs.ErrSystem + } + + defer func() { + if err != nil { + status = "failed" + charges = false + } else { + status = "success" + charges = true + } + sendApiRequestMessageErr := l.svcCtx.ApiRequestMqsService.SendApiRequestMessage(l.ctx, transactionID, userId, productCode, status, charges, remark) + if sendApiRequestMessageErr != nil { + logx.Errorf("发送 API 请求消息失败: %v", err) + } + }() + // 1、解密 + key, decodeErr := hex.DecodeString(secretKey) + if decodeErr != nil { + return "", errs.ErrSystem + } + decryptData, aesDecryptErr := crypto.AesDecrypt(req.Data, key) + if aesDecryptErr != nil || len(decryptData) == 0 { + return "", errs.ErrParamDecryption + } + + // 2、校验 + var data validator.FLXG0V3BRequest + if validatorErr := validator.ValidateAndParse(decryptData, &data); validatorErr != nil { + return "", errs.ErrParamValidation + } + + // 3、西部加密 + westConfig := l.svcCtx.Config.WestConfig + encryptedFields, encryptStructFieldsErr := common.EncryptStructFields(data, westConfig.Key) + if encryptStructFieldsErr != nil { + logx.Errorf("西部加密错误：%v", encryptStructFieldsErr) + return "", errs.ErrSystem + } + + // 4、发送请求到西部 + logx.Infof("交易号：%s", transactionID) + apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.FLXG0V3BFieldMapping, "data") + + westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G34BJ03", apiRequest, l.svcCtx.Config.WestConfig.SecretId) + if callAPIErr != nil { + if callAPIErr.Code == errs.ErrDataSource.Code { + encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key) + if aesEncrypt != nil { + return "", errs.ErrSystem + } + return encryptData, callAPIErr + } + return "", callAPIErr + } + + encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key) + if aesEncrypt != nil { + return "", errs.ErrSystem + } + return encryptData, nil +} diff --git a/apps/api/internal/validator/structs.go b/apps/api/internal/validator/structs.go index 8a2dd5d..4669785 100644 --- a/apps/api/internal/validator/structs.go +++ b/apps/api/internal/validator/structs.go @@ -16,6 +16,10 @@ type Name struct { } type FLXG3D56Request struct { + IDCard string `json:"id_card" validate:"required,validIDCard"` + Name string `json:"name" validate:"required,min=1,validName"` +} +type FLXG0V3BRequest struct { MobileNo string `json:"mobile_no" validate:"required,min=11,max=11,validMobileNo"` IDCard string `json:"id_card" validate:"required,validIDCard"` Name string `json:"name" validate:"required,min=1,validName"` diff --git a/apps/api/internal/westmodel/fieldMapping.go b/apps/api/internal/westmodel/fieldMapping.go index 6f945f9..b14a0d6 100644 --- a/apps/api/internal/westmodel/fieldMapping.go +++ b/apps/api/internal/westmodel/fieldMapping.go @@ -6,6 +6,10 @@ var FLXG3D56FieldMapping = map[string]string{ "MobileNo": "cell", "TimeRange": "time_range", } +var FLXG0V3BFieldMapping = map[string]string{ + "IDCard": "id_card", + "Name": "name", +} var FLXG54F5FieldMapping = map[string]string{ "MobileNo": "mobile", }