add clearData

sunty

2020-02-11 16bae3ac172893e8e3f66ef2532096105d885345

 controllers/clearData.go

@@ -11,15 +11,15 @@
   "webserver/extend/util"
)

type ClearDataController struct{}
type DeleteDataController struct{}

type clearParams struct {
type deleteParams struct {
   StartTime string `json:"startTime"`
   EndTime   string `json:"endTime"`
}

func (cdc *ClearDataController) ClearEsData(c *gin.Context) {
   var cp clearParams
func (cdc *DeleteDataController) DeleteEsData(c *gin.Context) {
   var cp deleteParams
   localConf, err := cache.GetServerInfo()
   if err != nil || localConf.AlarmIp == "" || localConf.ServerId == "" {
      logger.Debug("localConfig is wrong!!!")
@@ -34,7 +34,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, "校验数据失败")
      util.ResponseFormat(c, code.InvalidRequest, queryErr)
      return
   }
   if queryRes != true {
@@ -43,7 +43,7 @@
   }
   addRes, addErr := esutil.AddDelTask(ip, port, config.BasicFS.IndexName, startTime, endTime, analyServerId)
   if addErr != nil {
      util.ResponseFormat(c, code.InvalidRequest, "追加任务失败")
      util.ResponseFormat(c, code.InvalidRequest, addErr)
      return
   }
   if addRes != true {
@@ -52,7 +52,7 @@
   }
   deleteRes, deleteErr := esutil.DeleteAnalyServerData(ip, port, config.BasicFS.IndexName, startTime, endTime, analyServerId)
   if deleteErr != nil {
      util.ResponseFormat(c, code.InvalidRequest, "数据删除失败")
      util.ResponseFormat(c, code.InvalidRequest, deleteErr)
      return
   }
   if deleteRes != true {