All/Go/Wine-Server/handlers/manager/admin/trade/worker.go

package trade

import (
	"Wine-Server/utils"
	"Wine-Server/utils/tables"
	"github.com/gorilla/websocket"
)

func queryUser(conn *websocket.Conn, manager *tables.ManagerTable, data any) {
	var param queryUserParam
	err := utils.AnyTrans(data, &param)
	if err != nil {
		utils.Logger.Println(err)
		_ = conn.WriteJSON(utils.WsEvent("adminTradeQueryUserRes", utils.Fail("参数错误")))
		return
	}
	total, users, err := tables.UserQueryForAdmin(manager.Id, param.Id, param.Vip, param.Limit, param.Page)
	if err != nil {
		utils.Logger.Println(err)
		_ = conn.WriteJSON(utils.WsEvent("adminTradeQueryUserRes", utils.Fail("查询用户失败")))
		return
	}
	_ = conn.WriteJSON(utils.WsEvent(
		"adminTradeQueryUserRes",
		utils.Success(utils.JsonType{"total": total, "list": users}),
	))
}

func queryTrade(conn *websocket.Conn, manager *tables.ManagerTable, data any) {
	var param queryTradeParam
	err := utils.AnyTrans(data, &param)
	if err != nil {
		utils.Logger.Println(err)
		_ = conn.WriteJSON(utils.WsEvent("adminTradeQueryTradeRes", utils.Fail("参数错误")))
		return
	}
	total, trades, err := tables.TradeQueryForAdmin(manager.Id, param.Cond, param.Uid, param.Limit, param.Page)
	if err != nil {
		utils.Logger.Println(err)
		_ = conn.WriteJSON(utils.WsEvent("adminTradeQueryTradeRes", utils.Fail("查询订单失败")))
		return
	}
	_ = conn.WriteJSON(utils.WsEvent(
		"adminTradeQueryTradeRes",
		utils.Success(utils.JsonType{"total": total, "list": trades}),
	))
}

func refund(conn *websocket.Conn, manager *tables.ManagerTable, data any) {
	var param refundParam
	err := utils.AnyTrans(data, &param)
	if err != nil {
		utils.Logger.Println(err)
		_ = conn.WriteJSON(utils.WsEvent("adminTradeRefundRes", utils.Fail("参数错误")))
		return
	}
	trade := tables.TradeTable{Id: param.Tid}
	err = trade.Get()
	if err != nil {
		utils.Logger.Println(err)
		_ = conn.WriteJSON(utils.WsEvent("adminTradeRefundRes", utils.Fail("订单查询失败")))
		return
	}
	if trade.Cash < param.Cash {
		utils.Logger.Println(err)
		_ = conn.WriteJSON(utils.WsEvent("adminTradeRefundRes", utils.Fail("超出原订单金额")))
		return
	}
	fundTable := tables.RefundTable{Tid: param.Tid, Manager: manager.Id, Cash: param.Cash, Reason: param.Reason}
	err = fundTable.Insert()
	if err != nil {
		err = fundTable.Get()
		fundTable.Manager, fundTable.Cash, fundTable.Reason = manager.Id, param.Cash, param.Reason
		err = fundTable.UpdateSelf()
	}
	_ = conn.WriteJSON(utils.WsEvent("adminTradeRefundRes", utils.Success(nil)))
	user := tables.UserTable{Id: trade.Payer}
	_ = user.Get()
	user.RefundCount++
	user.BuyCost -= uint64(param.Cash)
	user.RefundCost += uint64(param.Cash)
	_ = user.UpdateSelf()
	operate := tables.OperationTable{
		UserType: 0, UserId: manager.Id, OpType: 5, Level: 2,
		Describe: utils.Format("订单号：%s，用户：%s，退款金额：%d", param.Tid, trade.Payer, param.Cash),
	}
	_ = operate.Insert()
}