redis.go
1.5 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
package models
import (
"client/sdkredis"
// "strconv"
)
/**
* 数据库所有数据导入redis
*/
func CloudArchiveM2R() {
// 查询数据库中所有数据
clouds, err := QueryCloudArchiveAll()
if err != nil {
return
}
// 连接redis
redisConn := sdkredis.RedisClient.GetConn()
defer sdkredis.RedisClose(redisConn)
// set key value
for _, cloud := range clouds {
_, err := sdkredis.RedisSetKV(redisConn, "ice_cloudarchive:"+cloud.UserId+":"+cloud.GameId, cloud.DataPacket)
if err != nil {
sdkredis.RedisClose(redisConn)
return
}
}
}
func (cloud *CloudArchive) SetCloudArchive(timeint int64) (err error) {
// timestr := string(timeint)
// 连接redis
redisConn := sdkredis.RedisClient.GetConn()
defer sdkredis.RedisClose(redisConn)
sdkredis.RedisSetKV(redisConn, "ice_cloudarchive:"+cloud.UserId+":"+cloud.GameId+":data", cloud.DataPacket)
// sdkredis.RedisGetKV(redisConn, "ice_cloudarchive:"+cloud.UserId+":"+cloud.GameId+":time", timestr)
if err != nil {
sdkredis.RedisClose(redisConn)
}
return
}
func (cloud *CloudArchive) GetCloudRedis() (data string, timeint int64, err error) {
redisConn := sdkredis.RedisClient.GetConn()
defer sdkredis.RedisClose(redisConn)
data, err = sdkredis.RedisGetKV(redisConn, "ice_cloudarchive:"+cloud.UserId+":"+cloud.GameId+":data")
// timestr, err := sdkredis.RedisGetKV(redisConn, "ice_cloudarchive:"+cloud.UserId+":"+cloud.GameId+":time")
// timeint, _ = int64(strconv.Atoi(timestr))
if err != nil {
sdkredis.RedisClose(redisConn)
}
return
}