Blame view

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