sunty
2020-02-11 4b45273f8970beddf8f788a9f90071b0ead0b4e2
controllers/clearData.go
@@ -4,6 +4,7 @@
   "basic.com/pubsub/esutil.git"
   "basic.com/valib/logger.git"
   "github.com/gin-gonic/gin"
   "log"
   "strconv"
   "webserver/cache"
   "webserver/extend/code"
@@ -34,7 +35,7 @@
   endTime := cp.EndTime
   queryRes, queryErr := esutil.QueryAnalyServerData(ip, port, config.EsInfo.EsIndex.AiOcean.IndexName, startTime, endTime, analyServerId)
   if queryErr != nil {
      util.ResponseFormat(c, code.InvalidRequest, queryErr)
      util.ResponseFormat(c, code.InvalidRequest, "校验数据失败")
      return
   }
   if queryRes != true {
@@ -43,7 +44,8 @@
   }
   addRes, addErr := esutil.AddDelTask(ip, port, config.BasicFS.IndexName, startTime, endTime, analyServerId)
   if addErr != nil {
      util.ResponseFormat(c, code.InvalidRequest, addErr)
      log.Println("错误为u:   ", addErr)
      util.ResponseFormat(c, code.InvalidRequest, "追加任务出错")
      return
   }
   if addRes != true {
@@ -52,7 +54,7 @@
   }
   deleteRes, deleteErr := esutil.DeleteAnalyServerData(ip, port, config.BasicFS.IndexName, startTime, endTime, analyServerId)
   if deleteErr != nil {
      util.ResponseFormat(c, code.InvalidRequest, deleteErr)
      util.ResponseFormat(c, code.InvalidRequest, "数据删除出错")
      return
   }
   if deleteRes != true {