|
|
|
@ -5,6 +5,7 @@ import (
|
|
|
|
"fmt"
|
|
|
|
"fmt"
|
|
|
|
"git.oa00.com/go/mysql"
|
|
|
|
"git.oa00.com/go/mysql"
|
|
|
|
gorm2 "gorm.io/gorm"
|
|
|
|
gorm2 "gorm.io/gorm"
|
|
|
|
|
|
|
|
"log"
|
|
|
|
"recook/internal/model/goods"
|
|
|
|
"recook/internal/model/goods"
|
|
|
|
"recook/internal/model/order"
|
|
|
|
"recook/internal/model/order"
|
|
|
|
"recook/internal/model/user"
|
|
|
|
"recook/internal/model/user"
|
|
|
|
@ -100,6 +101,7 @@ func PaySuccessCallback(tx *gorm.DB, orderInfo order.Information, completeTime f
|
|
|
|
if err := tx.Create(&profit).Error; err != nil {
|
|
|
|
if err := tx.Create(&profit).Error; err != nil {
|
|
|
|
return err
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
log.Println(12)
|
|
|
|
if row := tx.Model(&user.Wallet{}).Where("user_id = ?", orderInfo.SharerID).UpdateColumns(map[string]interface{}{
|
|
|
|
if row := tx.Model(&user.Wallet{}).Where("user_id = ?", orderInfo.SharerID).UpdateColumns(map[string]interface{}{
|
|
|
|
"balance": gorm2.Expr("balance + ?", profit.Income),
|
|
|
|
"balance": gorm2.Expr("balance + ?", profit.Income),
|
|
|
|
"version": gorm2.Expr("version + 1"),
|
|
|
|
"version": gorm2.Expr("version + 1"),
|
|
|
|
|
kanade
3 years ago