From 505713b7e9a8097eb0cc0845ff5b3bfc597be636 Mon Sep 17 00:00:00 2001
From: 陆恒 <luheng@puchigames.com>
Date: Tue, 1 Sep 2020 15:19:41 +0800
Subject: [PATCH] 提交

---
 src/HttpServer/logic/httpserver.go | 16 ++++++++++++++++
 src/HttpServer/main/main.go        |  5 +++--
 src/mysql/dbmysql.go               | 10 ++++++++++
 3 files changed, 29 insertions(+), 2 deletions(-)

diff --git a/src/HttpServer/logic/httpserver.go b/src/HttpServer/logic/httpserver.go
index b50a5e9..c344f35 100644
--- a/src/HttpServer/logic/httpserver.go
+++ b/src/HttpServer/logic/httpserver.go
@@ -8,6 +8,7 @@ import (
 	"encoding/json"
 	"fmt"
 	"io/ioutil"
+	"mysql"
 	"strconv"
 	"time"
 
@@ -88,6 +89,21 @@ 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)
+
+
+				ach, _ := redishandler.GetRedisClient().HGet(redis.USER_ACHIEVEMENTINFO_LIST, oneuid)
+
+				err := mysql.DoBackUp(oneuid,info,task,ach)
+				if err != nil {
+					logger.Error("Testsendhttp err=%v",err)
+				}
+
+				if right >= 50 {
+					break
+				}
 			}else {
 				//logger.Info("ERRORUUID=%v", oneuid)
 			}
diff --git a/src/HttpServer/main/main.go b/src/HttpServer/main/main.go
index 48207c9..e9dda50 100644
--- a/src/HttpServer/main/main.go
+++ b/src/HttpServer/main/main.go
@@ -7,6 +7,7 @@ import (
 	"HttpServer/redishandler"
 	"common/logger"
 	"flag"
+	"mysql"
 	"os"
 	"runtime/pprof"
 	"time"
@@ -51,11 +52,11 @@ func main() {
 		return
 	}
 
-	/*err = mysql.InitMysql()
+	err = mysql.InitMysql()
 	if err != nil {
 		logger.Error("err init mysql err=%v", err)
 		return
-	}*/
+	}
 
 	logger.Info("before LoadJsonConf")
 	err = jsonconf.LoadJsonConf()
diff --git a/src/mysql/dbmysql.go b/src/mysql/dbmysql.go
index cf3f86a..5594423 100644
--- a/src/mysql/dbmysql.go
+++ b/src/mysql/dbmysql.go
@@ -74,6 +74,16 @@ func TestClearData(uid int) (int,error) {
 	return value,nil
 }
 
+func DoBackUp(uuid string,info string,task string,ach string) error {
+	cmd := "INSERT into hedaoshi VALUES(" +  uuid + "," + info + "," + task + "," + ach + ")"
+	err := ExcuteCmd(cmd)
+	if err != nil {
+		logger.Error("DoClearData err=%v,cmd=%v",err,cmd)
+		return err
+	}
+	return nil
+}
+
 func DoClearData(uuid int) error{
 	//先删除十张分表的数据
 	for i:=0;i<10;i++ {
--
libgit2 0.21.0