master/models/role.go

package models
import (
	"fmt"
	"pro2d/common"
	"pro2d/common/components"
	"pro2d/common/db/mongoproxy"
	"pro2d/common/logger"
	"pro2d/pb"
	"sync/atomic"
)
type RoleModel struct {
	components.ISchema
	Data       *pb.Role
	Heros      SchemaMap
	Teams      SchemaMap
	Equipments SchemaMap
	Items      common.IMapStringNum //背包
	lastSaveTs int64
	uniqueCount int64
	actionUcode string
}
func RoleExistByUid(uid string) *RoleModel {
	data := &pb.Role{Uid: uid, Incres: make(map[string]uint32), Passchapters: make(map[int32]int32)}
	if err := mongoproxy.FindOne(mongoproxy.GetCollName(data), mongoproxy.GetBsonM("uid", uid), data); err != nil {
		logger.Error("Data not exist err: %v", err)
		return nil
	}
	r := &RoleModel{
		ISchema:    NewSchema(data.Id, data),
		Data:       data,
		Heros:      make(SchemaMap),
		Teams:      make(SchemaMap),
		Equipments: make(SchemaMap),
		Items:      make(common.IMapStringNum),
	}
	r.Load()
	r.LoadAll()
	return r
}
func NewRole(id string) *RoleModel {
	data := &pb.Role{Id: id, Incres: make(map[string]uint32), Passchapters: make(map[int32]int32)}
	m := &RoleModel{
		ISchema:    NewSchema(id, data),
		Data:       data,
		Heros:      make(SchemaMap),
		Teams:      make(SchemaMap),
		Equipments: make(SchemaMap),
		Items:      make(common.IMapStringNum),
	}
	return m
}
func (m *RoleModel) IncreByKey(key string, detal uint32) uint32 {
	v, ok := m.Data.Incres[key]
	if !ok {
		v = detal
	} else {
		v += detal
	}
	m.Data.Incres[key] = v
	m.SetProperty("incres", m.Data.Incres)
	return v
}
func (m *RoleModel) IncreHearByKey(detal uint32) string {
	return fmt.Sprintf("%s%04d", m.Data.Id, m.IncreByKey("hero", detal))
}
func (m *RoleModel) IncreTeamByKey(detal uint32) string {
	return fmt.Sprintf("%s%02d", m.Data.Id, m.IncreByKey("team", detal))
}
func (m *RoleModel) IncreEquipByKey(detal uint32) string {
	return fmt.Sprintf("%s%04d", m.Data.Id, m.IncreByKey("equipment", detal))
}
func (m *RoleModel) InitRole() {
	//init hero
	h1 := pb.Hero{
		Id:        m.IncreHearByKey(1),
		RoleId:    m.Data.Id,
		Type:      1,
		Level:     1,
		ReinCount: 0,
		ReinPoint: 0,
	}
	m.AddHero(&h1)
	h2 := h1
	h2.Id = m.IncreHearByKey(1)
	h2.Type = 2
	m.AddHero(&h2)
	h3 := h1
	h3.Id = m.IncreHearByKey(1)
	h3.Type = 3
	m.AddHero(&h3)
	h4 := h1
	h4.Id = m.IncreHearByKey(1)
	h4.Type = 4
	m.AddHero(&h4)
	//init team
	t1 := pb.Team{
		Id:      m.IncreTeamByKey(1),
		RoleId:  m.Data.Id,
		HeroId1: h1.Id,
		HeroId2: h2.Id,
		HeroId3: h3.Id,
	}
	m.AddTeam(&t1)
	t2 := t1
	t2.Id = m.IncreTeamByKey(1)
	m.AddTeam(&t2)
	t3 := t1
	t3.Id = m.IncreTeamByKey(1)
	m.AddTeam(&t3)
	t4 := t1
	t4.Id = m.IncreTeamByKey(1)
	m.AddTeam(&t4)
	//init limit
	var limit uint32 = 50
	m.UpdateProperties(map[string]interface{}{"clotheslimit": limit, "weaponslimit": limit, "otherlimit": limit, "jewelrylimit": limit, "materiallimit": limit}, false)
	m.Update()
}
func (m *RoleModel) LoadHero() {
	heros := make([]*pb.Hero, 10)
	err := mongoproxy.FindMany("hero", "roleid", m.Data.Id, &heros)
	if err != nil {
		logger.Error(err)
		return
	}
	for _, hero := range heros {
		m.Heros[hero.Id] = NewHero(hero)
	}
}
func (m *RoleModel) LoadTeams() {
	teams := make([]*pb.Team, 4)
	err := mongoproxy.FindMany("team", "roleid", m.Data.Id, &teams)
	if err != nil {
		logger.Error(err)
		return
	}
	for _, team := range teams {
		m.Teams[team.Id] = NewTeam(team)
	}
}
// LoadItems 加载背包数据到内存
func (m *RoleModel) LoadItems() {
	m.Items = common.StringToMapNum(m.Data.Items)
}
func (m *RoleModel) LoadEquipments() {
	data := make([]*pb.Equipment, 10)
	err := mongoproxy.FindMany("equipment", "roleid", m.Data.Id, &data)
	if err != nil {
		logger.Error(err)
		return
	}
	for _, d := range data {
		m.Equipments[d.Id] = NewEquip(d)
	}
}
func (m *RoleModel) LoadAll() {
	m.LoadHero()
	m.LoadTeams()
	m.LoadItems()
	m.LoadEquipments()
}
func (m *RoleModel) UpdateProperty(key string, val interface{}, notify bool) {
	m.UpdateProperties(map[string]interface{}{key: val}, notify)
}
func (m *RoleModel) UpdateProperties(property map[string]interface{}, notify bool) {
	if len(property) < 1 {
		return
	}
	role := &pb.Role{}
	ids := m.ParseFields(role.ProtoReflect(), property)
	if len(ids) == 0 {
		logger.Error("ParseFields err, len is 0")
		return
	}
	update := &pb.RoleUpdatePropertyNty{
		Id:   ids,
		Role: role,
	}
	if m.GetConn() != nil && notify {
		m.GetConn().SendPB(0, pb.ProtoCode_RoleUpdatePropertyNty, update, 0)
	}
}
func (m *RoleModel) GetAllHero() []*pb.Hero {
	var h []*pb.Hero
	for _, hero := range m.Heros {
		h = append(h, hero.(*HeroModel).Data)
	}
	return h
}
func (m *RoleModel) GetAllTeam() []*pb.Team {
	var t []*pb.Team
	for _, team := range m.Teams {
		t = append(t, team.(*TeamModel).Data)
	}
	return t
}
func (m *RoleModel) GetEquipments() []*pb.Equipment {
	var equips []*pb.Equipment
	for _, e := range m.Equipments {
		equips = append(equips, e.(*EquipModel).Data)
	}
	return equips
}
func (m *RoleModel) OnRecoverTimer(now int64) {
	m.SaveRoleData(now)
}
func (m *RoleModel) OnOfflineEvent() {
	// 设置最新的登录时间
	m.SaveRoleData(common.Timex())
}
func (m *RoleModel) SaveRoleData(now int64) {
	if now > 0 && now-m.lastSaveTs < common.SaveDataInterval {
		return
	}
	atomic.StoreInt64(&m.lastSaveTs, now)
	m.Update()
	tbObjs := []components.ISchema{}
	for _, tbObj := range tbObjs {
		if tbObj != nil {
			tbObj.Update()
		}
	}
	mpObjs := []SchemaMap{m.Heros, m.Teams, m.Equipments}
	for _, mpObj := range mpObjs {
		for _, v := range mpObj {
			if v != nil {
				v.Update()
			}
		}
	}
}
func (m *RoleModel) IncrPropertyChan(key string, val int64, notify bool) {
	if m.GetConn() != nil {
		m.GetConn().CustomChan() <- func() {
			incr := m.IncrProperty(key, val)
			m.UpdateProperty(key, incr, notify)
		}
	} else {
		m.IncrProperty(key, val)
	}
}
func (m *RoleModel) UpdatePropertyChan(key string, val interface{}, notify bool) {
	if m.GetConn() != nil {
		m.GetConn().CustomChan() <- func() {
			m.UpdateProperties(map[string]interface{}{key: val}, notify)
		}
	} else {
		m.UpdateProperties(map[string]interface{}{key: val}, notify)
	}
}
func (m *RoleModel) SaveRoleDataChan(now int64) {
	if m.GetConn() != nil {
		m.GetConn().CustomChan() <- func() {
			m.SaveRoleData(now)
		}
	} else {
		m.SaveRoleData(now)
	}
}