Commit 505713b7e9a8097eb0cc0845ff5b3bfc597be636
1 parent
f6cfe537
Exists in
master
提交
Showing
3 changed files
with
29 additions
and
2 deletions
Show diff stats
src/HttpServer/logic/httpserver.go
| @@ -8,6 +8,7 @@ import ( | @@ -8,6 +8,7 @@ import ( | ||
| 8 | "encoding/json" | 8 | "encoding/json" |
| 9 | "fmt" | 9 | "fmt" |
| 10 | "io/ioutil" | 10 | "io/ioutil" |
| 11 | + "mysql" | ||
| 11 | "strconv" | 12 | "strconv" |
| 12 | "time" | 13 | "time" |
| 13 | 14 | ||
| @@ -88,6 +89,21 @@ func Testsendhttp() { | @@ -88,6 +89,21 @@ func Testsendhttp() { | ||
| 88 | } | 89 | } |
| 89 | redishandler.GetRedisClient().HDel(redis.USER_TASKINFO_LIST, oneuid) | 90 | redishandler.GetRedisClient().HDel(redis.USER_TASKINFO_LIST, oneuid) |
| 90 | redishandler.GetRedisClient().HDel(redis.USER_ACHIEVEMENTINFO_LIST, oneuid)*/ | 91 | redishandler.GetRedisClient().HDel(redis.USER_ACHIEVEMENTINFO_LIST, oneuid)*/ |
| 92 | + //存入mysql | ||
| 93 | + info,_ := redishandler.GetRedisClient().HGet(redis.USER_DATA_KEY, oneuid) | ||
| 94 | + task, _ := redishandler.GetRedisClient().HGet(redis.USER_TASKINFO_LIST, oneuid) | ||
| 95 | + | ||
| 96 | + | ||
| 97 | + ach, _ := redishandler.GetRedisClient().HGet(redis.USER_ACHIEVEMENTINFO_LIST, oneuid) | ||
| 98 | + | ||
| 99 | + err := mysql.DoBackUp(oneuid,info,task,ach) | ||
| 100 | + if err != nil { | ||
| 101 | + logger.Error("Testsendhttp err=%v",err) | ||
| 102 | + } | ||
| 103 | + | ||
| 104 | + if right >= 50 { | ||
| 105 | + break | ||
| 106 | + } | ||
| 91 | }else { | 107 | }else { |
| 92 | //logger.Info("ERRORUUID=%v", oneuid) | 108 | //logger.Info("ERRORUUID=%v", oneuid) |
| 93 | } | 109 | } |
src/HttpServer/main/main.go
| @@ -7,6 +7,7 @@ import ( | @@ -7,6 +7,7 @@ import ( | ||
| 7 | "HttpServer/redishandler" | 7 | "HttpServer/redishandler" |
| 8 | "common/logger" | 8 | "common/logger" |
| 9 | "flag" | 9 | "flag" |
| 10 | + "mysql" | ||
| 10 | "os" | 11 | "os" |
| 11 | "runtime/pprof" | 12 | "runtime/pprof" |
| 12 | "time" | 13 | "time" |
| @@ -51,11 +52,11 @@ func main() { | @@ -51,11 +52,11 @@ func main() { | ||
| 51 | return | 52 | return |
| 52 | } | 53 | } |
| 53 | 54 | ||
| 54 | - /*err = mysql.InitMysql() | 55 | + err = mysql.InitMysql() |
| 55 | if err != nil { | 56 | if err != nil { |
| 56 | logger.Error("err init mysql err=%v", err) | 57 | logger.Error("err init mysql err=%v", err) |
| 57 | return | 58 | return |
| 58 | - }*/ | 59 | + } |
| 59 | 60 | ||
| 60 | logger.Info("before LoadJsonConf") | 61 | logger.Info("before LoadJsonConf") |
| 61 | err = jsonconf.LoadJsonConf() | 62 | err = jsonconf.LoadJsonConf() |
src/mysql/dbmysql.go
| @@ -74,6 +74,16 @@ func TestClearData(uid int) (int,error) { | @@ -74,6 +74,16 @@ func TestClearData(uid int) (int,error) { | ||
| 74 | return value,nil | 74 | return value,nil |
| 75 | } | 75 | } |
| 76 | 76 | ||
| 77 | +func DoBackUp(uuid string,info string,task string,ach string) error { | ||
| 78 | + cmd := "INSERT into hedaoshi VALUES(" + uuid + "," + info + "," + task + "," + ach + ")" | ||
| 79 | + err := ExcuteCmd(cmd) | ||
| 80 | + if err != nil { | ||
| 81 | + logger.Error("DoClearData err=%v,cmd=%v",err,cmd) | ||
| 82 | + return err | ||
| 83 | + } | ||
| 84 | + return nil | ||
| 85 | +} | ||
| 86 | + | ||
| 77 | func DoClearData(uuid int) error{ | 87 | func DoClearData(uuid int) error{ |
| 78 | //先删除十张分表的数据 | 88 | //先删除十张分表的数据 |
| 79 | for i:=0;i<10;i++ { | 89 | for i:=0;i<10;i++ { |