package controllers
|
|
import (
|
"basic.com/pubsub/esutil.git"
|
"basic.com/valib/logger.git"
|
"github.com/gin-gonic/gin"
|
"strconv"
|
"webserver/cache"
|
"webserver/extend/code"
|
"webserver/extend/config"
|
"webserver/extend/util"
|
)
|
|
type Buckers struct {
|
}
|
|
func (b *Buckers) GetBuckets(c *gin.Context) {
|
var info interface{}
|
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))
|
c.BindJSON(&info)
|
inf := info.(map[string]interface{})
|
startTime := inf["startTime"].(string)
|
endTime := inf["endTime"].(string)
|
cameraId := inf["cameraId"].([]string)
|
thresholdTime := inf["thresholdTime"].(float64)
|
resDate, err := esutil.GetfaceDataBucketsBycameraIdAndTime(cameraId, startTime, endTime, thresholdTime, ip, port, config.EsInfo.EsIndex.AiOcean.IndexName)
|
if err != nil {
|
util.ResponseFormat(c, code.FailedQuery, err)
|
return
|
}
|
util.ResponseFormat(c, code.Success, resDate)
|
}
|
