From a5d8d660ad26df113bebdea79e93f3f8ba5cf381 Mon Sep 17 00:00:00 2001 From: 陆恒 Date: Tue, 1 Sep 2020 18:10:13 +0800 Subject: [PATCH] 提交 --- src/HttpServer/logic/httpserver.go | 19 ++++++++----------- src/mysql/dbmysql.go | 3 ++- 2 files changed, 10 insertions(+), 12 deletions(-) diff --git a/src/HttpServer/logic/httpserver.go b/src/HttpServer/logic/httpserver.go index 5d46f56..aa23689 100644 --- a/src/HttpServer/logic/httpserver.go +++ b/src/HttpServer/logic/httpserver.go @@ -90,29 +90,26 @@ func Testsendhttp() { redishandler.GetRedisClient().HDel(redis.USER_TASKINFO_LIST, oneuid) redishandler.GetRedisClient().HDel(redis.USER_ACHIEVEMENTINFO_LIST, oneuid)*/ //存入mysql - //info,_ := redishandler.GetRedisClient().HGet(redis.USER_DATA_KEY, oneuid) - //task, _ := redishandler.GetRedisClient().HGet(redis.USER_TASKINFO_LIST, oneuid) + info,_ := redishandler.GetRedisClient().HGet(redis.USER_DATA_KEY, oneuid) + task, _ := redishandler.GetRedisClient().HGet(redis.USER_TASKINFO_LIST, oneuid) - //ach, _ := redishandler.GetRedisClient().HGet(redis.USER_ACHIEVEMENTINFO_LIST, oneuid) + ach, _ := redishandler.GetRedisClient().HGet(redis.USER_ACHIEVEMENTINFO_LIST, oneuid) - err := mysql.DoBackUp(oneuid,"info","task","ach") + err := mysql.DoBackUp(oneuid,info,task,ach) if err != nil { logger.Error("Testsendhttp err=%v",err) } - if right >= 2 { - break - } }else { if oneuid == "5943465P_D_BL01_4" { - //info,_ := redishandler.GetRedisClient().HGet(redis.USER_DATA_KEY, oneuid) - //task, _ := redishandler.GetRedisClient().HGet(redis.USER_TASKINFO_LIST, oneuid) + info,_ := redishandler.GetRedisClient().HGet(redis.USER_DATA_KEY, oneuid) + task, _ := redishandler.GetRedisClient().HGet(redis.USER_TASKINFO_LIST, oneuid) - //ach, _ := redishandler.GetRedisClient().HGet(redis.USER_ACHIEVEMENTINFO_LIST, oneuid) + ach, _ := redishandler.GetRedisClient().HGet(redis.USER_ACHIEVEMENTINFO_LIST, oneuid) - err := mysql.DoBackUp(oneuid,"1","task","ach") + err := mysql.DoBackUp(oneuid,info,task,ach) if err != nil { logger.Error("Testsendhttp err=%v",err) } diff --git a/src/mysql/dbmysql.go b/src/mysql/dbmysql.go index 5594423..21d29be 100644 --- a/src/mysql/dbmysql.go +++ b/src/mysql/dbmysql.go @@ -75,7 +75,8 @@ func TestClearData(uid int) (int,error) { } func DoBackUp(uuid string,info string,task string,ach string) error { - cmd := "INSERT into hedaoshi VALUES(" + uuid + "," + info + "," + task + "," + ach + ")" + cmd := fmt.Sprintf("INSERT into hedaoshi VALUES(%s,%s,%s,%s) ON DUPLICATE KEY UPDATE update info=%s ,task=%s,ach=%s", uuid,info,task,ach,info,task,ach) + //cmd := "INSERT into hedaoshi VALUES(" + uuid + "," + info + "," + task + "," + ach + ")" err := ExcuteCmd(cmd) if err != nil { logger.Error("DoClearData err=%v,cmd=%v",err,cmd) -- libgit2 0.21.0