提交新街口

陆恒
1 parent b5304fef
Showing 2 changed files with 68 additions and 2 deletions Show diff stats
src/HttpServer/logic/httpserver.go
src/mysql/dbmysql.go
@@ -37,6 +37,7 @@ func startServerHttpServe() {
 	//-------------------------------------------------------------
 	http.HandleFunc("/catcafe/ClearData", ClearData)	//情况账号的测试接口
 	http.HandleFunc("/catcafe/AddWhiteList", AddWhiteList)	//情况账号的测试接口
+	http.HandleFunc("/catcafe/QueryAllAccount", QueryAllAccount)	//查询所有账号的等级信息等数据
 	//-------------------------------------------------------------
 	http.HandleFunc("/catcafe/login", UserLogin)                                    //游客登录
 	http.HandleFunc("/catcafe/user/regeister", Regeister)                                    //账号注册
@@ -71,6 +72,15 @@ func startServerHttpServe() {
 	CheckErr(err)
 }
  
+func QueryAllAccount(w http.ResponseWriter, r *http.Request) {
+
+	logger.Info("QueryAllAccount ")
+
+
+	mysql.QueryAllData()
+}
+
+
 func AddWhiteList(w http.ResponseWriter, r *http.Request) {
  
 	query := r.URL.Query()
@@ -86,8 +96,8 @@ func AddWhiteList(w http.ResponseWriter, r *http.Request) {
 	if err!= nil {
 		fmt.Fprint(w, "添加白名单失败，err=%v",err)
 	}else {
-		fmt.Fprint(w, "添加白名单成功！")
-	}
+	fmt.Fprint(w, "添加白名单成功！")
+}
  
 }
  
@@ -2,10 +2,12 @@ package mysql
  
 import (
 	"HttpServer/conf"
+	"bufio"
 	"common/logger"
 	"database/sql"
 	"fmt"
 	_ "github.com/go-sql-driver/mysql"
+	"os"
 	"strconv"
 )
  
@@ -85,4 +87,58 @@ func DoClearData(uuid int) error{
 	}
 	return nil
  
+}
+
+func checkFileIsExist(filename string) bool {
+	var exist = true
+	if _, err := os.Stat(filename); os.IsNotExist(err) {
+		exist = false
+	}
+	return exist
+}
+
+func QueryAllData() error{
+	//先打开文件
+	filename := "./data.txt"
+	var f *os.File
+//	var err1 error
+	if checkFileIsExist(filename) { //如果文件存在
+		f, _ = os.OpenFile(filename, os.O_APPEND, 0666) //打开文件
+	} else {
+		f, _ = os.Create(filename) //创建文件
+	}
+	//先查询十张分表的数据
+	for i:=0;i<10;i++ {
+		tablename := "b_base_data_0" + strconv.Itoa(i)
+		cmd := "SELECT user_id,lv,exp,login_time from " + tablename
+		rows, err := m_game_db.Query(cmd)
+		defer func() {
+			if rows != nil {
+				rows.Close() //可以关闭掉未scan连接一直占用
+			}
+		}()
+		if err != nil {
+			logger.Error("Query failed,err:%v", err)
+			return err
+		}
+		for rows.Next() {
+			Uid := 0
+			Ulv := 0
+			Exp := 0
+			LoginTime := 0
+			err = rows.Scan(&Uid, &Ulv, &Exp,&LoginTime) //不scan会导致连接不释放
+			if err != nil {
+				logger.Error("Scan failed,err:%v", err)
+				return err
+			}
+
+			w := bufio.NewWriter(f)
+
+			str := string(Uid) + " " + string(Ulv) + " " + string(Exp) + " " + string(LoginTime)
+			fmt.Fprintln(w, str)
+			w.Flush()
+		}
+	}
+	return nil
+
 }
 \ No newline at end of file
...	...	@@ -37,6 +37,7 @@ func startServerHttpServe() {
37	37	//-------------------------------------------------------------
38	38	http.HandleFunc("/catcafe/ClearData", ClearData) //情况账号的测试接口
39	39	http.HandleFunc("/catcafe/AddWhiteList", AddWhiteList) //情况账号的测试接口
	40	+ http.HandleFunc("/catcafe/QueryAllAccount", QueryAllAccount) //查询所有账号的等级信息等数据
40	41	//-------------------------------------------------------------
41	42	http.HandleFunc("/catcafe/login", UserLogin) //游客登录
42	43	http.HandleFunc("/catcafe/user/regeister", Regeister) //账号注册
...	...	@@ -71,6 +72,15 @@ func startServerHttpServe() {
71	72	CheckErr(err)
72	73	}
73	74
	75	+func QueryAllAccount(w http.ResponseWriter, r *http.Request) {
	76	+
	77	+ logger.Info("QueryAllAccount ")
	78	+
	79	+
	80	+ mysql.QueryAllData()
	81	+}
	82	+
	83	+
74	84	func AddWhiteList(w http.ResponseWriter, r *http.Request) {
75	85
76	86	query := r.URL.Query()
...	...	@@ -86,8 +96,8 @@ func AddWhiteList(w http.ResponseWriter, r *http.Request) {
86	96	if err!= nil {
87	97	fmt.Fprint(w, "添加白名单失败，err=%v",err)
88	98	}else {
89		- fmt.Fprint(w, "添加白名单成功！")
90		- }
	99	+ fmt.Fprint(w, "添加白名单成功！")
	100	+}
91	101
92	102	}
93	103
...	...
...	...	@@ -2,10 +2,12 @@ package mysql
2	2
3	3	import (
4	4	"HttpServer/conf"
	5	+ "bufio"
5	6	"common/logger"
6	7	"database/sql"
7	8	"fmt"
8	9	_ "github.com/go-sql-driver/mysql"
	10	+ "os"
9	11	"strconv"
10	12	)
11	13
...	...	@@ -85,4 +87,58 @@ func DoClearData(uuid int) error{
85	87	}
86	88	return nil
87	89
	90	+}
	91	+
	92	+func checkFileIsExist(filename string) bool {
	93	+ var exist = true
	94	+ if _, err := os.Stat(filename); os.IsNotExist(err) {
	95	+ exist = false
	96	+ }
	97	+ return exist
	98	+}
	99	+
	100	+func QueryAllData() error{
	101	+ //先打开文件
	102	+ filename := "./data.txt"
	103	+ var f *os.File
	104	+// var err1 error
	105	+ if checkFileIsExist(filename) { //如果文件存在
	106	+ f, _ = os.OpenFile(filename, os.O_APPEND, 0666) //打开文件
	107	+ } else {
	108	+ f, _ = os.Create(filename) //创建文件
	109	+ }
	110	+ //先查询十张分表的数据
	111	+ for i:=0;i<10;i++ {
	112	+ tablename := "b_base_data_0" + strconv.Itoa(i)
	113	+ cmd := "SELECT user_id,lv,exp,login_time from " + tablename
	114	+ rows, err := m_game_db.Query(cmd)
	115	+ defer func() {
	116	+ if rows != nil {
	117	+ rows.Close() //可以关闭掉未scan连接一直占用
	118	+ }
	119	+ }()
	120	+ if err != nil {
	121	+ logger.Error("Query failed,err:%v", err)
	122	+ return err
	123	+ }
	124	+ for rows.Next() {
	125	+ Uid := 0
	126	+ Ulv := 0
	127	+ Exp := 0
	128	+ LoginTime := 0
	129	+ err = rows.Scan(&Uid, &Ulv, &Exp,&LoginTime) //不scan会导致连接不释放
	130	+ if err != nil {
	131	+ logger.Error("Scan failed,err:%v", err)
	132	+ return err
	133	+ }
	134	+
	135	+ w := bufio.NewWriter(f)
	136	+
	137	+ str := string(Uid) + " " + string(Ulv) + " " + string(Exp) + " " + string(LoginTime)
	138	+ fmt.Fprintln(w, str)
	139	+ w.Flush()
	140	+ }
	141	+ }
	142	+ return nil
	143	+
88	144	}
89	145	\ No newline at end of file
...	...