fix(order): improve error logging for database transaction and user cache updates
This commit is contained in:
parent
1c1365d862
commit
83c1c14b01
@ -646,7 +646,7 @@ func (l *ActivateOrderLogic) Recharge(ctx context.Context, orderInfo *order.Orde
|
|||||||
// Update balance in transaction
|
// Update balance in transaction
|
||||||
err = l.svc.DB.Transaction(func(tx *gorm.DB) error {
|
err = l.svc.DB.Transaction(func(tx *gorm.DB) error {
|
||||||
userInfo.Balance += orderInfo.Price
|
userInfo.Balance += orderInfo.Price
|
||||||
if err := l.svc.UserModel.Update(ctx, userInfo, tx); err != nil {
|
if err = l.svc.UserModel.Update(ctx, userInfo, tx); err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -668,7 +668,13 @@ func (l *ActivateOrderLogic) Recharge(ctx context.Context, orderInfo *order.Orde
|
|||||||
})
|
})
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
logger.WithContext(ctx).Error("Database transaction failed", logger.Field("error", err.Error()))
|
logger.WithContext(ctx).Error("[Recharge] Database transaction failed", logger.Field("error", err.Error()))
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
// clear user cache
|
||||||
|
if err = l.svc.UserModel.UpdateUserCache(ctx, userInfo); err != nil {
|
||||||
|
logger.WithContext(ctx).Error("[Recharge] Update user cache failed", logger.Field("error", err.Error()))
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user