Blame view

models/role_test.go 2.85 KB
ee23102d   zhangqijia   支持mongo, grpc接服务器
1
2
3
  package models
  
  import (
1584eb4b   zhangqijia   修复创建唯一索引的bug
4
  	"fmt"
765431a4   zhangqijia   增加schema接口, 抽象 mo...
5
  	"pro2d/common"
436e0af4   zhangqijia   reactor: dir; Ac...
6
  	"pro2d/common/db/mongoproxy"
765431a4   zhangqijia   增加schema接口, 抽象 mo...
7
  	"pro2d/common/logger"
7f269318   zhangqijia   add pb.go; 添加关闭连接...
8
  	"pro2d/pb"
f631f225   zhangqijia   feat: 增加背包系统,以及背包...
9
10
  	"strconv"
  	"strings"
ee23102d   zhangqijia   支持mongo, grpc接服务器
11
  	"testing"
ee23102d   zhangqijia   支持mongo, grpc接服务器
12
13
14
  )
  
  func TestNewRole(t *testing.T) {
a24dea4c   zhangqijia   fix: id自增做了写更新。阵容...
15
  	err := mongoproxy.ConnectMongo(common.GlobalConf.GameConf.MongoConf, common.GlobalConf.GameConf.ID)
765431a4   zhangqijia   增加schema接口, 抽象 mo...
16
17
18
19
  	if err != nil {
  		logger.Error(err)
  		return
  	}
ee23102d   zhangqijia   支持mongo, grpc接服务器
20
  
33ea26ab   zhangqijia   使用schema封装mongo
21
  	var uid = "141815055745814528"
cad2b7f3   zhangqijia   reactor: 重构目录, 重构...
22
23
  	role := RoleExistByUid(uid)
  	if role != nil {
1584eb4b   zhangqijia   修复创建唯一索引的bug
24
  		//uid存在 , 更新角色
33ea26ab   zhangqijia   使用schema封装mongo
25
26
27
28
29
30
31
32
33
  		//role.AddHero(&pb.Hero{
  		//	Id:         1,
  		//	RoleId:     role.Role.Id,
  		//	Type:       0,
  		//	Level:      0,
  		//	ReinCount:  0,
  		//	ReinPoint:  0,
  		//	Equipments: "",
  		//})
7f269318   zhangqijia   add pb.go; 添加关闭连接...
34
  		role.SetProperty("Device", "1111")
33ea26ab   zhangqijia   使用schema封装mongo
35
  		//role.Save()
d771e9e3   zhangqijia   fix: 优化FieldByNam...
36
  	} else {
1584eb4b   zhangqijia   修复创建唯一索引的bug
37
  		//uid不存在,创建角色
33ea26ab   zhangqijia   使用schema封装mongo
38
  		role = NewRole("1")
1584eb4b   zhangqijia   修复创建唯一索引的bug
39
40
  		role.Role.Uid = uid
  		role.Role.Device = "111111"
ee23102d   zhangqijia   支持mongo, grpc接服务器
41
  		role.Role.Level = 0
33ea26ab   zhangqijia   使用schema封装mongo
42
43
  		err := role.Create()
  		fmt.Println(err)
ee23102d   zhangqijia   支持mongo, grpc接服务器
44
45
  	}
  	print(role)
1584eb4b   zhangqijia   修复创建唯一索引的bug
46
47
48
  }
  
  func TestRoleIndex(t *testing.T) {
8d983031   zhangqijia   loginReq uid -> t...
49
  	coll, keys := mongoproxy.FindIndex(pb.Role{})
d771e9e3   zhangqijia   fix: 优化FieldByNam...
50
  	for _, index := range keys {
cad2b7f3   zhangqijia   reactor: 重构目录, 重构...
51
  		logger.Debug("coll: %s, key: %s", coll, index)
1584eb4b   zhangqijia   修复创建唯一索引的bug
52
  	}
8d983031   zhangqijia   loginReq uid -> t...
53
54
55
  }
  
  func TestRoleModel_AddHero(t *testing.T) {
a24dea4c   zhangqijia   fix: id自增做了写更新。阵容...
56
  	err := mongoproxy.ConnectMongo(common.GlobalConf.GameConf.MongoConf, common.GlobalConf.GameConf.ID)
8d983031   zhangqijia   loginReq uid -> t...
57
58
59
60
61
62
63
64
65
66
67
68
69
  	if err != nil {
  		logger.Error(err)
  		return
  	}
  
  	var uid = "141815055745814528"
  	role := RoleExistByUid(uid)
  	if role == nil {
  		logger.Error("role not exist")
  		return
  	}
  
  	role.InitRole()
4255fd8e   zhangqijia   feat: 更新字段
70
71
72
  }
  
  func TestRoleModel_ProtoReflect(t *testing.T) {
a24dea4c   zhangqijia   fix: id自增做了写更新。阵容...
73
  	err := mongoproxy.ConnectMongo(common.GlobalConf.GameConf.MongoConf, common.GlobalConf.GameConf.ID)
4255fd8e   zhangqijia   feat: 更新字段
74
75
76
77
78
  	if err != nil {
  		logger.Error(err)
  		return
  	}
  
d771e9e3   zhangqijia   fix: 优化FieldByNam...
79
80
81
82
83
  	sch := NewRole("")
  	//mp := map[string]interface{}{
  	//	"Id": "1",
  	//	"Device": "12312312312",
  	//}
f631f225   zhangqijia   feat: 增加背包系统,以及背包...
84
  	sch.UpdateProperty("Device", "123123123", false)
d771e9e3   zhangqijia   fix: 优化FieldByNam...
85
86
  	fmt.Println(sch.Role)
  }
a24dea4c   zhangqijia   fix: id自增做了写更新。阵容...
87
  
eadc9aff   zhangqijia   feat: 增加上阵下阵协议,增加...
88
  func TestRoleModel_UpdateTeam(t *testing.T) {
a24dea4c   zhangqijia   fix: id自增做了写更新。阵容...
89
  	err := mongoproxy.ConnectMongo(common.GlobalConf.GameConf.MongoConf, common.GlobalConf.GameConf.ID)
eadc9aff   zhangqijia   feat: 增加上阵下阵协议,增加...
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
  	if err != nil {
  		logger.Error(err)
  		return
  	}
  	sch := NewRole("1")
  	sch.Load()
  	sch.LoadAll()
  	sch.UpdateTeam([]*pb.Team{
  		&pb.Team{
  			Id:      "147262174025748480",
  			RoleId:  "",
  			HeroId1: "",
  			HeroId2: "",
  			HeroId3: "",
  		},
  	})
  	sch.OnOfflineEvent()
  }
a24dea4c   zhangqijia   fix: id自增做了写更新。阵容...
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
  
  func TestRoleModel_IncreByKey(t *testing.T) {
  	//err := mongoproxy.ConnectMongo(common.GlobalConf.GameConf.MongoConf, common.GlobalConf.GameConf.ID)
  	//if err != nil {
  	//	logger.Error(err)
  	//	return
  	//}
  	//sch := NewRole("1000001")
  	//sch.Load()
  	//sch.LoadAll()
  	//
  	//sch.Role.Incres["hero"] = 4
  	//sch.Role.Incres["team"] = 4
  	//sch.SetProperty("incres", sch.Role.Incres)
  	//sch.Update()
  
  	fmt.Printf("%03d\n", 3)
f631f225   zhangqijia   feat: 增加背包系统,以及背包...
125
126
127
128
  
  	ites := strings.SplitN("1=1 2=2 3=3", " ", -1)
  	fmt.Println(ites)
  
17fe96be   zhangqijia   feat: 增加装备相关数据和协议
129
  	items := make(IMapString)
f631f225   zhangqijia   feat: 增加背包系统,以及背包...
130
131
132
133
134
135
136
137
138
139
140
141
  	for _, v := range ites {
  		ii := strings.Split(v, "=")
  		if len(ii) < 2 {
  			continue
  		}
  		n, err := strconv.ParseUint(ii[1], 10, 32)
  		if err != nil {
  			continue
  		}
  		items[ii[0]] = uint32(n)
  	}
  	fmt.Println(items)
a24dea4c   zhangqijia   fix: id自增做了写更新。阵容...
142
  }