From fc31c6481c1e1d9b510f8f3a86281af56db97af6 Mon Sep 17 00:00:00 2001 From: 陆恒 Date: Mon, 31 Aug 2020 16:14:33 +0800 Subject: [PATCH] 提交 --- src/HttpServer/logic/httpserver.go | 28 ++++++++++++++++++++++++++++ src/HttpServer/main/main.go | 3 ++- 2 files changed, 30 insertions(+), 1 deletion(-) diff --git a/src/HttpServer/logic/httpserver.go b/src/HttpServer/logic/httpserver.go index b94c91d..cd51e8d 100644 --- a/src/HttpServer/logic/httpserver.go +++ b/src/HttpServer/logic/httpserver.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") diff --git a/src/HttpServer/main/main.go b/src/HttpServer/main/main.go index 7365561..787d965 100644 --- a/src/HttpServer/main/main.go +++ b/src/HttpServer/main/main.go @@ -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: -- libgit2 0.21.0