liuxiaolong
2020-06-05 7c811247ecf143e08c576986a884bedadc57dd66
controllers/clearData.go
@@ -3,6 +3,7 @@
import (
   "basic.com/pubsub/esutil.git"
   "basic.com/valib/logger.git"
   "fmt"
   "github.com/gin-gonic/gin"
   "strconv"
   "webserver/cache"
@@ -41,18 +42,20 @@
      util.ResponseFormat(c, code.InvalidRequest, "数据已删除或该时间段无数据")
      return
   }
   fmt.Println("asgdasgdjhas: ", ip, port, config.BasicFS.IndexName, startTime, endTime, analyServerId)
   addRes, addErr := esutil.AddDelTask(ip, port, config.BasicFS.IndexName, startTime, endTime, analyServerId)
   if addErr != nil {
      util.ResponseFormat(c, code.InvalidRequest, "追加任务失败")
      fmt.Println("错误为u:   ", addErr)
      util.ResponseFormat(c, code.InvalidRequest, "追加任务出错")
      return
   }
   if addRes != true {
      util.ResponseFormat(c, code.InvalidRequest, "追加任务失败")
      return
   }
   deleteRes, deleteErr := esutil.DeleteAnalyServerData(ip, port, config.BasicFS.IndexName, startTime, endTime, analyServerId)
   deleteRes, deleteErr := esutil.DeleteAnalyServerData(ip, port, config.EsInfo.EsIndex.AiOcean.IndexName, startTime, endTime, analyServerId)
   if deleteErr != nil {
      util.ResponseFormat(c, code.InvalidRequest, "数据删除失败")
      util.ResponseFormat(c, code.InvalidRequest, "数据删除出错")
      return
   }
   if deleteRes != true {