102 lines
3.3 KiB
Go
102 lines
3.3 KiB
Go
|
package pay
|
||
|
|
|
||
|
|
import (
|
||
|
|
"context"
|
||
|
|
"encoding/json"
|
||
|
|
"fmt"
|
||
|
|
"github.com/pkg/errors"
|
||
|
|
"github.com/zeromicro/go-zero/core/logx"
|
||
|
|
"github.com/zeromicro/go-zero/core/stores/sqlx"
|
||
|
|
"qnc-server/app/user/cmd/api/internal/svc"
|
||
|
|
"qnc-server/app/user/cmd/api/internal/types"
|
||
|
|
"qnc-server/app/user/model"
|
||
|
|
"qnc-server/common/ctxdata"
|
||
|
|
"qnc-server/common/xerr"
|
||
|
|
)
|
||
|
|
|
||
|
|
type PaymentLogic struct {
|
||
|
|
logx.Logger
|
||
|
|
ctx context.Context
|
||
|
|
svcCtx *svc.ServiceContext
|
||
|
|
}
|
||
|
|
|
||
|
|
func NewPaymentLogic(ctx context.Context, svcCtx *svc.ServiceContext) *PaymentLogic {
|
||
|
|
return &PaymentLogic{
|
||
|
|
Logger: logx.WithContext(ctx),
|
||
|
|
ctx: ctx,
|
||
|
|
svcCtx: svcCtx,
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
func (l *PaymentLogic) Payment(req *types.PaymentReq) (resp *types.PaymentResp, err error) {
|
||
|
|
userID, getUidErr := ctxdata.GetUidFromCtx(l.ctx)
|
||
|
|
if getUidErr != nil {
|
||
|
|
return nil, errors.Wrapf(xerr.NewErrCode(xerr.SERVER_COMMON_ERROR), "生成订单, 获取用户信息失败, %+v", getUidErr)
|
||
|
|
}
|
||
|
|
redisKey := fmt.Sprintf("%d:%s", userID, req.Id)
|
||
|
|
cache, cacheErr := l.svcCtx.Redis.GetCtx(l.ctx, redisKey)
|
||
|
|
if cacheErr != nil {
|
||
|
|
return nil, cacheErr
|
||
|
|
}
|
||
|
|
var data types.QueryCache
|
||
|
|
err = json.Unmarshal([]byte(cache), &data)
|
||
|
|
if err != nil {
|
||
|
|
return nil, errors.Wrapf(xerr.NewErrCode(xerr.SERVER_COMMON_ERROR), "生成订单, 解析缓存内容失败, %+v", err)
|
||
|
|
}
|
||
|
|
|
||
|
|
product, err := l.svcCtx.ProductModel.FindOneByProductEn(l.ctx, data.Product)
|
||
|
|
if err != nil {
|
||
|
|
return nil, errors.Wrapf(xerr.NewErrCode(xerr.SERVER_COMMON_ERROR), "生成订单, 查找产品错误: %+v", err)
|
||
|
|
}
|
||
|
|
|
||
|
|
var prepayID string
|
||
|
|
outTradeNo := l.svcCtx.WechatPayService.GenerateOutTradeNo()
|
||
|
|
var createOrderErr error
|
||
|
|
if req.PayMethod == "wechatpay" {
|
||
|
|
prepayID, createOrderErr = l.svcCtx.WechatPayService.CreateWechatAppOrder(l.ctx, product.SellPrice, product.Description, outTradeNo)
|
||
|
|
} else {
|
||
|
|
prepayID, createOrderErr = l.svcCtx.AlipayService.CreateAlipayAppOrder(product.SellPrice, product.Description, outTradeNo)
|
||
|
|
}
|
||
|
|
if createOrderErr != nil {
|
||
|
|
return nil, errors.Wrapf(xerr.NewErrCode(xerr.SERVER_COMMON_ERROR), "生成订单, 创建支付订单失败: %+v", createOrderErr)
|
||
|
|
}
|
||
|
|
var orderID int64
|
||
|
|
transErr := l.svcCtx.OrderModel.Trans(l.ctx, func(ctx context.Context, session sqlx.Session) error {
|
||
|
|
order := model.Order{
|
||
|
|
OrderNo: outTradeNo,
|
||
|
|
UserId: userID,
|
||
|
|
ProductId: product.Id,
|
||
|
|
PaymentPlatform: req.PayMethod,
|
||
|
|
PaymentScene: "app",
|
||
|
|
Amount: product.SellPrice,
|
||
|
|
Status: "pending",
|
||
|
|
}
|
||
|
|
orderInsertResult, insertOrderErr := l.svcCtx.OrderModel.Insert(ctx, session, &order)
|
||
|
|
if insertOrderErr != nil {
|
||
|
|
return errors.Wrapf(xerr.NewErrCode(xerr.SERVER_COMMON_ERROR), "生成订单, 保存订单失败: %+v", insertOrderErr)
|
||
|
|
}
|
||
|
|
insertedOrderID, lastInsertIdErr := orderInsertResult.LastInsertId()
|
||
|
|
if lastInsertIdErr != nil {
|
||
|
|
return errors.Wrapf(xerr.NewErrCode(xerr.SERVER_COMMON_ERROR), "生成订单, 获取保存订单ID失败: %+v", lastInsertIdErr)
|
||
|
|
}
|
||
|
|
orderID = insertedOrderID
|
||
|
|
query := model.Query{
|
||
|
|
OrderId: orderID,
|
||
|
|
UserId: userID,
|
||
|
|
ProductId: product.Id,
|
||
|
|
QueryParams: cache,
|
||
|
|
QueryState: "pending",
|
||
|
|
}
|
||
|
|
_, insertQueryErr := l.svcCtx.QueryModel.Insert(l.ctx, session, &query)
|
||
|
|
if insertQueryErr != nil {
|
||
|
|
return insertQueryErr
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
})
|
||
|
|
if transErr != nil {
|
||
|
|
return nil, transErr
|
||
|
|
}
|
||
|
|
|
||
|
|
return &types.PaymentResp{PrepayID: prepayID, OrderID: orderID}, nil
|
||
|
|
}
|