temp

apps/api/internal/logic/FLXG/flxg3d56logic.go

@@ -32,6 +32,9 @@ func NewFLXG3D56Logic(ctx context.Context, svcCtx *svc.ServiceContext) *FLXG3D56
 
 // FLXG3D56 特殊名单
 func (l *FLXG3D56Logic) FLXG3D56(req *types.Request) (resp *types.Response, err *errs.AppError) {
+	var status string
+	var charges bool
+	var remark = ""
 	secretKey, ok := l.ctx.Value("secretKey").(string)
 	if !ok {
 		return &types.Response{}, errs.ErrSystem
@@ -40,6 +43,29 @@ func (l *FLXG3D56Logic) FLXG3D56(req *types.Request) (resp *types.Response, err
 	if !ok {
 		return &types.Response{}, errs.ErrSystem
 	}
+	userId, userIdOk := l.ctx.Value("userId").(int64)
+	if !userIdOk {
+		return &types.Response{}, errs.ErrSystem
+	}
+	productCode, productCodeOk := l.ctx.Value("productCode").(string)
+	if !productCodeOk || productCode == "" {
+		return &types.Response{}, 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 {
@@ -87,6 +113,7 @@ func (l *FLXG3D56Logic) FLXG3D56(req *types.Request) (resp *types.Response, err
 	if aesEncrypt != nil {
 		return nil, errs.ErrSystem
 	}
+
 	return &types.Response{
 		Data: encryptData,
 	}, nil