package service import ( "blazing/cool" "blazing/modules/player/model" "context" "github.com/gogf/gf/v2/frame/g" ) func (s *ItemService) Exist(itemid uint32) bool { var ttt *model.Item s.dbm(s.Model).Where("item_id", itemid).Scan(&ttt) return ttt != nil } func (s *ItemService) Get(min, max uint32) []model.Item { var ttt []model.Item s.dbm(s.Model).Where(g.Map{ "item_id <=": max, "item_id >=": min, }).Scan(&ttt) return ttt } func (s *ItemService) UPDATE(id uint32, count int) { if cool.Config.ServerInfo.IsVip != 0 && count < 0 { return } if id == 0 { return } m := s.dbm(s.Model) ok, err := m.Where("item_id", id).Exist() if err != nil { panic(err) } if ok { _, err := s.dbm(s.Model).Where("item_id", id).Increment("item_cnt", count) if err != nil { panic(err) } } else { m := s.dbm(s.Model) data := g.Map{ "player_id": s.userid, "item_id": id, "item_cnt": count, "is_vip": cool.Config.ServerInfo.IsVip, } m.Data(data).Insert() } } // func (s *ItemService) UPDATEM(ids map[uint32]int) { // if cool.Config.ServerInfo.IsVip != 0 { // return // } // m := s.dbm(s.Model) // data := g.List{} // for k, v := range ids { // data = append(data, g.Map{ // "player_id": s.userid, // "item_id": k, // "item_cnt": v, // "is_vip": cool.Config.ServerInfo.IsVip, // }) // } // m.Data(data).Insert() // } func (s *ItemService) CheakItem(id uint32) int64 { var ttt model.Item m := s.dbm(s.Model) m.Where("item_id", id).Scan(&ttt) return ttt.ItemCnt } func (s *ItemService) CheakItemM(id ...uint32) []model.Item { var ttt []model.Item m := s.dbm(s.Model) m.WhereIn("item_id", id).Scan(&ttt) return ttt } // /添加进来的物品一定是保证存在的 type ItemService struct { BaseService } func NewItemService(id uint32) *ItemService { return &ItemService{ BaseService: BaseService{userid: id, Service: &cool.Service{Model: model.NewPlayerBag(), UniqueKey: map[string]string{ "player_id": "角色名称不能重复", }, PageQueryOp: &cool.QueryOp{ KeyWordField: []string{"player_id"}, FieldEQ: []string{"player_id"}, Where: func(ctx context.Context) [][]interface{} { var ( //admin = cool.GetAdmin(ctx) //userId = admin.UserId ) return [][]interface{}{ // {"player_id", userId, true}, // {"free", 0, true}, } }, }}, }, } }