Blame view

src/models/init.go 759 Bytes
3592dfd3   zhangqijia   重构models, 索引唯一索引
1
2
3
  package models
  
  import (
3592dfd3   zhangqijia   重构models, 索引唯一索引
4
  	"pro2d/protos/pb"
cad2b7f3   zhangqijia   reactor: 重构目录, 重构...
5
6
7
  	"pro2d/src/components/db"
  	"pro2d/src/components/logger"
  	"pro2d/src/utils"
3592dfd3   zhangqijia   重构models, 索引唯一索引
8
9
10
11
  )
  
  func InitDoc(schema ...interface{})  {
  	for _, s := range schema {
1584eb4b   zhangqijia   修复创建唯一索引的bug
12
13
14
  		coll, keys := utils.FindIndex(s)
  		for  _, index := range keys {
  			db.CreateCollection(coll)
3592dfd3   zhangqijia   重构models, 索引唯一索引
15
  
cad2b7f3   zhangqijia   reactor: 重构目录, 重构...
16
  			logger.Debug("InitDoc collect: %v, createIndex: %s", coll, index)
1584eb4b   zhangqijia   修复创建唯一索引的bug
17
  			res, err := db.SetUnique(coll, index)
3592dfd3   zhangqijia   重构models, 索引唯一索引
18
  			if err != nil {
cad2b7f3   zhangqijia   reactor: 重构目录, 重构...
19
  				logger.Error("InitDoc unique: %s, err: %v", res, err)
3592dfd3   zhangqijia   重构models, 索引唯一索引
20
21
22
23
24
25
26
27
  				continue
  			}
  		}
  	}
  }
  
  func InitAccountServerModels()  {
  	var schema []interface{} = []interface{}{
563acaf7   zhangqijia   在拦截器中认证jwt
28
  		pb.Account{},
3592dfd3   zhangqijia   重构models, 索引唯一索引
29
30
31
32
33
34
35
36
37
38
39
40
  	}
  	InitDoc(schema...)
  }
  
  func InitGameServerModels()  {
  	var schema []interface{} = []interface{}{
  		pb.Hero{},
  		pb.Role{},
  		pb.Team{},
  	}
  	InitDoc(schema...)
  }