add clearData

sunty

2020-01-15 49ceaa0374fb3f0d74a4949953b0355359b3bf49

add clearData

 controllers/clearData.go

New file
@@ -0,0 +1,64 @@
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 ClearDataController struct{}

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

func (cdc *ClearDataController) ClearEsData(c *gin.Context) {
    var cp clearParams
    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
    }
    addRes, addErr := esutil.AddDelTask(ip, port, config.BasicFS.IndexName, startTime, endTime, analyServerId)
    if addErr != nil {
        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)
    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
}

 extend/code/code.go

@@ -29,6 +29,7 @@
    UploadSuffixError = &Code{http.StatusBadRequest, false, "该上传文件格式目前暂不支持"}
    // UploadSizeLimit 目前上传仅支持小于5M的文件内容
    UploadSizeLimit = &Code{http.StatusBadRequest, false, "目前上传仅支持小于5M的文件内容"}
    InvalidRequest  = &Code{http.StatusBadRequest, false, "请求无效"}
    LoginSuccess    = &Code{http.StatusOK, true, "登录成功"}
    // SigninInfoError 账户名或密码有误
    LoginInfoError = &Code{http.StatusUnauthorized, false, "用户名或密码错误"}
@@ -67,5 +68,5 @@
    AddClusterInfoErr   = &Code{http.StatusInternalServerError, false, "加入节点失败！"}

    UpgradeSuccess = &Code{http.StatusOK, true, "升级成功"}
    UpgradeFail = &Code{http.StatusInternalServerError, false, "升级失败"}
    UpgradeFail    = &Code{http.StatusInternalServerError, false, "升级失败"}
)

 extend/config/config.go

@@ -29,8 +29,8 @@
    SudoPassword  string      `mapstructure: "sudoPassword"` //系统密码
    SysThresholds []threshold `mapstructure: "sysThresholds"`
    PTZSpeed      int         `mapstructure: "ptzSpeed"` // 云台移动速度
    PatchPath       string `mapstructure:"patchPath"`//系统更新包路径
    BakPath         string `mapstructure:"bakPath"`//系统更新包路径
    PatchPath     string      `mapstructure:"patchPath"` //系统更新包路径
    BakPath       string      `mapstructure:"bakPath"`   //系统更新包路径
}

var Server = &server{}
@@ -42,7 +42,7 @@
}

type esindexlist struct {
    AiOcean   index `mapstructure:"aiOcean"`
    AiOcean index `mapstructure:"aiOcean"`
}
type index struct {
    IndexName string `mapstructure:"index"`
@@ -54,9 +54,16 @@
    Port string `mapstructure:"port"`
}

type elastic struct {
    IndexName string `mapstructure: "indexName"`
    IndexType string `mapstructure: "indexType"`
}

var SoPath = &sopath{}

var EsInfo = &esinfo{}

var BasicFS = &elastic{}

type facedetect struct {
    Ip   string `mapstructure:"Ip"`
@@ -88,7 +95,7 @@
    viper.AddConfigPath("/opt/vasystem/config/")
    err = viper.ReadInConfig()
    if err != nil {
        log.Fatal("error on parsing configuration file",err)
        log.Fatal("error on parsing configuration file", err)
    }
    viper.UnmarshalKey("es", EsInfo)
    viper.UnmarshalKey("server", Server)
@@ -96,4 +103,5 @@
    viper.UnmarshalKey("facedetect", FaceDetectSet)
    viper.UnmarshalKey("dbpersoncompare", DbPersonCompInfo)
    viper.UnmarshalKey("espersoncompare", EsCompServerInfo)
    viper.UnmarshalKey("elastic.basicFS", BasicFS)
}

 router/router.go

@@ -28,6 +28,7 @@
    esSearchController := new(controllers.EsSearchController)
    esManagementController := new(controllers.EsManagementController)
    realTimeController := new(controllers.RealTimeController)
    clearDataController := new(controllers.ClearDataController)
    cameraTimeRuleController := new(controllers.CameraTimeruleController)
    polygonController := new(controllers.CameraPolygonController)
    cameraTaskController := new(controllers.CameraTaskController)
@@ -47,7 +48,7 @@

    urlPrefix := "/data/api-v" // wp 添加 路径 前缀

    licenseApi :=r.Group(urlPrefix+"/license")
    licenseApi := r.Group(urlPrefix + "/license")
    {
        licenseApi.POST("/getRegisterCode", licenseController.GetRegisterCode)
        licenseApi.POST("/save", licenseController.Save)
@@ -181,6 +182,12 @@
        realTime.POST("/initForCaptureData", realTimeController.InitForCaptureData)
        realTime.POST("/initForMonitoringData", realTimeController.InitForMonitoringData)
    }
    //清理数据
    clearData := r.Group(urlPrefix + "/clearData")
    {
        clearData.POST("/clearEsData", clearDataController.ClearEsData)
    }

    //底库 操作
    vdbtable := r.Group(urlPrefix + "/dbtable")
    {
@@ -233,8 +240,8 @@
        vsset.GET("/rebootTask", ssController.GetRebootTask)
        vsset.POST("/rebootTask", ssController.SetRebootTask)

        vsset.GET("/getResourceConfig",ssController.GetResourceConfig)
        vsset.POST("/saveResourceConfig",ssController.SaveResourceConfig)
        vsset.GET("/getResourceConfig", ssController.GetResourceConfig)
        vsset.POST("/saveResourceConfig", ssController.SaveResourceConfig)
        vsset.GET("/patchUpdate", ssController.PatchUpdateCheck)
        vsset.POST("/patchUpdate", ssController.PatchUpdate)
        vsset.POST("/upgrade", ssController.Upgrade)
@@ -299,13 +306,13 @@
    fileAnalyApi := r.Group(urlPrefix + "/fileAnalysis")
    {
        fileAnalyApi.GET("/findAllFile", fileAnalysisC.FindAllFile)
        fileAnalyApi.POST("/updateStatus",fileAnalysisC.UpdateStatus)
        fileAnalyApi.POST("/delete",fileAnalysisC.Delete)
        fileAnalyApi.POST("/sortFile",fileAnalysisC.SortFile)
        fileAnalyApi.POST("/updateStatus", fileAnalysisC.UpdateStatus)
        fileAnalyApi.POST("/delete", fileAnalysisC.Delete)
        fileAnalyApi.POST("/sortFile", fileAnalysisC.SortFile)
    }
    fileSettingApi := r.Group(urlPrefix + "/fileSetting")
    {
        fileSettingApi.GET("/show",fileSettingC.Show)
        fileSettingApi.GET("/show", fileSettingC.Show)
        fileSettingApi.POST("/changeEnable", fileSettingC.ChangeEnable)
    }