package call

import (
	"fmt"
	"server/common"
	"server/db"
	"server/pb"

	"github.com/liangdas/mqant/log"
)

func GetUserItem(uid, itemID int) []*common.PlayerItems {
	list := []*common.PlayerItems{}
	db.Mysql().QueryAll(fmt.Sprintf("uid = %d and item_id = %d", uid, itemID), "", &common.PlayerItems{}, &list)
	return list
}

func GetItem(id, uid int) *common.PlayerItems {
	list := &common.PlayerItems{ID: id, UID: uid, Status: common.ItemStatusNormal}
	db.Mysql().Get(&list)
	return list
}
func GetUserValidItems(uid, itemID int) []*common.PlayerItems {
	list := []*common.PlayerItems{}
	db.Mysql().QueryAll(fmt.Sprintf("uid = %d and item_id = %d and status = %d", uid, itemID, common.ItemStatusNormal), "", &common.PlayerItems{}, &list)
	return list
}

func GetUserItemByExi1(uid, itemID, exi1 int) []*common.PlayerItems {
	list := []*common.PlayerItems{}
	db.Mysql().QueryAll(fmt.Sprintf("uid = %d and item_id = %d and exi1 = %d and status = %d", uid, itemID, exi1, common.ItemStatusNormal), "", &common.PlayerItems{}, &list)
	return list
}

// 获取力度最大的折扣券
func GetUserBestDiscountTicket(uid int) *common.PlayerItems {
	list := []*common.PlayerItems{}
	db.Mysql().QueryAll(fmt.Sprintf("uid = %d and item_id = %d and status = %d", uid, common.ItemDiscountTicket, common.ItemStatusNormal), "exi1 desc", &common.PlayerItems{}, &list)
	if len(list) > 0 {
		return list[0]
	}
	return nil
}

func AddUserDiscountTicket(uid int, exi1, exi2, t, exi3 int64, notify bool) {
	err := db.Mysql().Create(&common.PlayerItems{UID: uid, ItemID: common.ItemDiscountTicket, Time: t, Status: common.ItemStatusNormal, Exi1: exi1, Exi2: exi2, Exi3: exi3})
	if err != nil {
		log.Error("AddUserDiscountTicket err:%v", err)
	}
	if notify {
		SendNR(uid, int(pb.ServerCommonResp_CommonDisCountTicketResp), &pb.DiscountTicketNotify{Discount: exi1, Amount: exi2}, "common")
	}
}