Commit 8e0caf5dceb3a951403cf518efcc7334bdc9f456
1 parent
e1b48da1
Exists in
master
提交
Showing
4 changed files
with
28 additions
and
8 deletions
Show diff stats
src/HttpServer/logic/httpserver.go
| @@ -25,6 +25,24 @@ func StartHttpServe() { | @@ -25,6 +25,24 @@ func StartHttpServe() { | ||
| 25 | startServerHttpServe() | 25 | startServerHttpServe() |
| 26 | } | 26 | } |
| 27 | 27 | ||
| 28 | +//测试单个号 | ||
| 29 | +func TestBackUpOen(uniqueid string) { | ||
| 30 | + info,_ := redishandler.GetRedisClient().HGet(redis.USER_DATA_KEY, uniqueid) | ||
| 31 | + task, _ := redishandler.GetRedisClient().HGet(redis.USER_TASKINFO_LIST, uniqueid) | ||
| 32 | + ach, _ := redishandler.GetRedisClient().HGet(redis.USER_ACHIEVEMENTINFO_LIST, uniqueid) | ||
| 33 | + | ||
| 34 | + err := mysql.DoBackUp(uniqueid,info,task,ach) | ||
| 35 | + if err != nil { | ||
| 36 | + logger.Error("Testsendhttp err=%v",err) | ||
| 37 | + }else { | ||
| 38 | + //删除 | ||
| 39 | + redishandler.GetRedisClient().HDel(redis.USER_DATA_KEY, uniqueid) | ||
| 40 | + redishandler.GetRedisClient().HDel(redis.USER_TASKINFO_LIST, uniqueid) | ||
| 41 | + redishandler.GetRedisClient().HDel(redis.USER_ACHIEVEMENTINFO_LIST, uniqueid) | ||
| 42 | + logger.Info("RIGHTUUID=%v", uniqueid) | ||
| 43 | + } | ||
| 44 | +} | ||
| 45 | + | ||
| 28 | 46 | ||
| 29 | func ClearTaskAndAchieve() { | 47 | func ClearTaskAndAchieve() { |
| 30 | logger.Info("start ClearTaskAndAchieve") | 48 | logger.Info("start ClearTaskAndAchieve") |
src/HttpServer/main/main.go
| @@ -71,7 +71,8 @@ func main() { | @@ -71,7 +71,8 @@ func main() { | ||
| 71 | //go logic.StartHttpTicker() | 71 | //go logic.StartHttpTicker() |
| 72 | //time.Sleep(time.Duration(2) * time.Second) | 72 | //time.Sleep(time.Duration(2) * time.Second) |
| 73 | //go logic.ClearTaskAndAchieve() | 73 | //go logic.ClearTaskAndAchieve() |
| 74 | - go logic.Testsendhttp() | 74 | + //go logic.Testsendhttp() |
| 75 | + logic.TestBackUpOen("5212786test") | ||
| 75 | 76 | ||
| 76 | select { | 77 | select { |
| 77 | case _ = <-ch: | 78 | case _ = <-ch: |
src/common/redis/def.go
| 1 | package redis | 1 | package redis |
| 2 | 2 | ||
| 3 | const ( | 3 | const ( |
| 4 | - //USER_DATA_KEY = "STARSTAR_USER_DATA_KEY" //玩家数据 | ||
| 5 | - USER_DATA_KEY = "HEDAOSHI_USER_DATA_KEY" //玩家数据 | 4 | + USER_DATA_KEY = "STARSTAR_USER_DATA_KEY" //玩家数据 |
| 5 | + //USER_DATA_KEY = "HEDAOSHI_USER_DATA_KEY" //玩家数据 | ||
| 6 | USER_WITHDRAW_RECORDLIST = "STARSTAR_USER_WITHDRAW_RECORDLIST" //玩家提现记录 | 6 | USER_WITHDRAW_RECORDLIST = "STARSTAR_USER_WITHDRAW_RECORDLIST" //玩家提现记录 |
| 7 | - USER_TASKINFO_LIST = "HEDAOSHI_USER_TASKINFO_LIST" //任务列表数据缓存 | ||
| 8 | - //USER_TASKINFO_LIST = "STARSTAR_USER_TASKINFO_LIST" //任务列表数据缓存 | ||
| 9 | - USER_ACHIEVEMENTINFO_LIST = "HEDAOSHI_USER_ACHIEVEMENTINFO_LIST" //成就列表数据缓存 | ||
| 10 | - //USER_ACHIEVEMENTINFO_LIST = "STARSTAR_USER_ACHIEVEMENTINFO_LIST" //成就列表数据缓存 | 7 | + //USER_TASKINFO_LIST = "HEDAOSHI_USER_TASKINFO_LIST" //任务列表数据缓存 |
| 8 | + USER_TASKINFO_LIST = "STARSTAR_USER_TASKINFO_LIST" //任务列表数据缓存 | ||
| 9 | + //USER_ACHIEVEMENTINFO_LIST = "HEDAOSHI_USER_ACHIEVEMENTINFO_LIST" //成就列表数据缓存 | ||
| 10 | + USER_ACHIEVEMENTINFO_LIST = "STARSTAR_USER_ACHIEVEMENTINFO_LIST" //成就列表数据缓存 | ||
| 11 | 11 | ||
| 12 | ) | 12 | ) |
src/mysql/dbmysql.go
| @@ -74,8 +74,9 @@ func TestClearData(uid int) (int,error) { | @@ -74,8 +74,9 @@ func TestClearData(uid int) (int,error) { | ||
| 74 | return value,nil | 74 | return value,nil |
| 75 | } | 75 | } |
| 76 | 76 | ||
| 77 | +//煮意替换表名！！！！ | ||
| 77 | func DoBackUp(uuid string,info string,task string,ach string) error { | 78 | func DoBackUp(uuid string,info string,task string,ach string) error { |
| 78 | - cmd := "INSERT into hedaoshi VALUES('"+uuid +"','" + info + "','" + task +"','"+ ach + "') ON DUPLICATE KEY UPDATE info=" + "'" + info + "', " + "task=" +"'"+ task + "', achieve='" + ach +"'" | 79 | + cmd := "INSERT into starstar VALUES('"+uuid +"','" + info + "','" + task +"','"+ ach + "') ON DUPLICATE KEY UPDATE info=" + "'" + info + "', " + "task=" +"'"+ task + "', achieve='" + ach +"'" |
| 79 | //cmd := "INSERT into hedaoshi VALUES(" + uuid + "," + info + "," + task + "," + ach + ")" | 80 | //cmd := "INSERT into hedaoshi VALUES(" + uuid + "," + info + "," + task + "," + ach + ")" |
| 80 | err := ExcuteCmd(cmd) | 81 | err := ExcuteCmd(cmd) |
| 81 | if err != nil { | 82 | if err != nil { |