package controllers

import (
	"basic.com/pubsub/esutil.git"
	"basic.com/valib/logger.git"
	"fmt"
	"github.com/gin-gonic/gin"
	"strconv"
	"webserver/cache"
	"webserver/extend/code"
	"webserver/extend/config"
	"webserver/extend/util"
)

type DeleteDataController struct{}

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

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!!!")
		util.ResponseFormat(c, code.ComError, "es config err")
		return
	}
	ip := localConf.AlarmIp
	port := strconv.Itoa(int(localConf.AlarmPort))
	analyServerId := localConf.ServerId
	c.BindJSON(&cp)
	startTime := cp.StartTime
	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, "校验数据失败")
		return
	}
	if queryRes != true {
		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 {
		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.EsInfo.EsIndex.AiOcean.IndexName, startTime, endTime, analyServerId)
	if deleteErr != nil {
		util.ResponseFormat(c, code.InvalidRequest, "数据删除出错")
		return
	}
	if deleteRes != true {
		util.ResponseFormat(c, code.InvalidRequest, "数据删除失败")
		return
	}
	util.ResponseFormat(c, code.Success, deleteRes)
	return
}