|
|
|
@ -4,8 +4,6 @@ import (
|
|
|
|
|
"errors"
|
|
|
|
|
"fmt"
|
|
|
|
|
"git.oa00.com/go/mysql"
|
|
|
|
|
gorm2 "gorm.io/gorm"
|
|
|
|
|
"log"
|
|
|
|
|
"recook/internal/model/goods"
|
|
|
|
|
"recook/internal/model/order"
|
|
|
|
|
"recook/internal/model/user"
|
|
|
|
@ -101,10 +99,9 @@ func PaySuccessCallback(tx *gorm.DB, orderInfo order.Information, completeTime f
|
|
|
|
|
if err := tx.Create(&profit).Error; err != nil {
|
|
|
|
|
return err
|
|
|
|
|
}
|
|
|
|
|
log.Println(12)
|
|
|
|
|
if row := tx.Model(&user.Wallet{}).Where("user_id = ?", orderInfo.SharerID).UpdateColumns(map[string]interface{}{
|
|
|
|
|
"balance": gorm2.Expr("balance + ?", profit.Income),
|
|
|
|
|
"version": gorm2.Expr("version + 1"),
|
|
|
|
|
"balance": gorm.Expr("balance + ?", profit.Income),
|
|
|
|
|
"version": gorm.Expr("version + 1"),
|
|
|
|
|
}).RowsAffected; row == 0 {
|
|
|
|
|
e := fmt.Errorf("网络异常")
|
|
|
|
|
return e
|
|
|
|
|