提交

陆恒
1 parent ceb9af5e
Showing 2 changed files with 30 additions and 1 deletions Show diff stats
src/HttpServer/logic/httpserver.go
src/HttpServer/main/main.go
@@ -24,6 +24,34 @@ func StartHttpServe() {
 	startServerHttpServe()
 }
  
+
+func ClearTaskAndAchieve() {
+	logger.Info("start ClearTaskAndAchieve")
+	result, err := redishandler.GetRedisClient().HGetAllKeys(redis.USER_TASKINFO_LIST)
+	if err != nil {
+		logger.Error("TestDDt failed err=%v",err)
+		return
+	}
+
+	right := 0
+	for _, v := range result {
+
+		ss := v.([]byte)
+		oneuid := string(ss)
+
+
+		//读取数据
+		data, err := GetUserInfo(oneuid)
+		if err != nil || data == nil {
+			logger.Info("RIGHTUUID=%v",oneuid)
+		}else {
+			continue
+		}
+
+
+	}
+	logger.Info("FINAL++++++++++++++++++++++++++++res=%v",right)
+}
 //just for test
 func Testsendhttp() {
 	logger.Info("start Testsendhttp")
@@ -69,7 +69,8 @@ func main() {
 	//go logic.StartHttpServe()
 	//go logic.StartHttpTicker()
 	//time.Sleep(time.Duration(2) * time.Second)
-	go logic.Testsendhttp()
+	go logic.ClearTaskAndAchieve()
+	//go logic.Testsendhttp()
  
 	select {
 	case _ = <-ch:
...	...	@@ -24,6 +24,34 @@ func StartHttpServe() {
24	24	startServerHttpServe()
25	25	}
26	26
	27	+
	28	+func ClearTaskAndAchieve() {
	29	+ logger.Info("start ClearTaskAndAchieve")
	30	+ result, err := redishandler.GetRedisClient().HGetAllKeys(redis.USER_TASKINFO_LIST)
	31	+ if err != nil {
	32	+ logger.Error("TestDDt failed err=%v",err)
	33	+ return
	34	+ }
	35	+
	36	+ right := 0
	37	+ for _, v := range result {
	38	+
	39	+ ss := v.([]byte)
	40	+ oneuid := string(ss)
	41	+
	42	+
	43	+ //读取数据
	44	+ data, err := GetUserInfo(oneuid)
	45	+ if err != nil \|\| data == nil {
	46	+ logger.Info("RIGHTUUID=%v",oneuid)
	47	+ }else {
	48	+ continue
	49	+ }
	50	+
	51	+
	52	+ }
	53	+ logger.Info("FINAL++++++++++++++++++++++++++++res=%v",right)
	54	+}
27	55	//just for test
28	56	func Testsendhttp() {
29	57	logger.Info("start Testsendhttp")
...	...
...	...	@@ -69,7 +69,8 @@ func main() {
69	69	//go logic.StartHttpServe()
70	70	//go logic.StartHttpTicker()
71	71	//time.Sleep(time.Duration(2) * time.Second)
72		- go logic.Testsendhttp()
	72	+ go logic.ClearTaskAndAchieve()
	73	+ //go logic.Testsendhttp()
73	74
74	75	select {
75	76	case _ = <-ch:
...	...