shanshanzhong147
d74803bcbe
- P04: fix Withdrawal.TableName() to return 'withdrawals' - P03: add WithdrawalStatus* and WithdrawalMethod* constants; replace magic numbers; add CommissionTypeWithdrawCancel=338 - P01: add POST /v1/public/user/withdrawal_cancel to cancel pending withdrawals with ownership check, row lock, commission refund, and audit log - P02: add method/account/qr_code_url fields to Withdrawal model and API; add input validation (qr_code_url required for Alipay/Wechat, account required for bank) - P05: add method filter to admin GET /v1/admin/user/withdrawal/list Co-authored-by: multica-agent <github@multica.ai>
49 lines
1.2 KiB
Go
49 lines
1.2 KiB
Go
package common
|
|
|
|
import (
|
|
"context"
|
|
"time"
|
|
|
|
"github.com/perfect-panel/server/internal/model/log"
|
|
usermodel "github.com/perfect-panel/server/internal/model/user"
|
|
"github.com/pkg/errors"
|
|
"gorm.io/gorm"
|
|
"gorm.io/gorm/clause"
|
|
)
|
|
|
|
func WriteCommissionLog(tx *gorm.DB, objectID int64, logType uint16, amount int64, orderNo string) error {
|
|
logInfo := log.Commission{
|
|
Type: logType,
|
|
Amount: amount,
|
|
OrderNo: orderNo,
|
|
Timestamp: time.Now().UnixMilli(),
|
|
}
|
|
|
|
content, err := logInfo.Marshal()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
return tx.Model(log.SystemLog{}).Create(&log.SystemLog{
|
|
Type: log.TypeCommission.Uint8(),
|
|
Date: time.Now().Format(time.DateOnly),
|
|
ObjectID: objectID,
|
|
Content: string(content),
|
|
CreatedAt: time.Now(),
|
|
}).Error
|
|
}
|
|
|
|
func LoadPendingWithdrawalForUpdate(ctx context.Context, tx *gorm.DB, withdrawalID int64) (*usermodel.Withdrawal, error) {
|
|
var withdrawal usermodel.Withdrawal
|
|
if err := tx.WithContext(ctx).
|
|
Clauses(clause.Locking{Strength: "UPDATE"}).
|
|
Where("id = ?", withdrawalID).
|
|
First(&withdrawal).Error; err != nil {
|
|
return nil, err
|
|
}
|
|
if withdrawal.Status != usermodel.WithdrawalStatusPending {
|
|
return nil, errors.New("withdrawal status invalid")
|
|
}
|
|
return &withdrawal, nil
|
|
}
|