add get buckets contrl

sunty

2020-08-20 9d88c7c467f8d93af4aab9ba0b6d6c01c2ffc546

 router/router.go

@@ -1,22 +1,20 @@
package router

import (
   "github.com/gin-gonic/gin"
   "github.com/swaggo/gin-swagger"
   "github.com/swaggo/gin-swagger/swaggerFiles"
   "github.com/szuecs/gin-glog"
   "time"
   "webserver/controllers"
   "webserver/middlewares/auth"

   "github.com/gin-gonic/gin"
   "github.com/swaggo/gin-swagger"
   "github.com/swaggo/gin-swagger/swaggerFiles"
   _ "webserver/docs"
)

func NewRouter() *gin.Engine {
   r := gin.Default()
   r.Use(ginglog.Logger(3 * time.Second))
   //r.Use(ginglog.Logger(3 * time.Second))

   r.Use(auth.AuthHandler())//auth过滤器
   r.Use(auth.AuthHandler()) //auth过滤器

   r.GET("/swagger/*any", ginSwagger.WrapHandler(swaggerFiles.Handler))

@@ -27,56 +25,83 @@
   dbPersonCont := new(controllers.DbPersonController)
   ssController := new(controllers.SysSetController)
   sdkController := new(controllers.SdkController)
   bucketsController := new(controllers.Buckers)
   esSearchController := new(controllers.EsSearchController)
   esManagementController := new(controllers.EsManagementController)
   realTimeController := new(controllers.RealTimeController)
   deleteDataController := new(controllers.DeleteDataController)
   cameraTimeRuleController := new(controllers.CameraTimeruleController)
   polygonController := new(controllers.CameraPolygonController)
   cameraTaskController := new(controllers.CameraTaskController)
   cameraTaskArgsController := new(controllers.CameraTaskArgsController)
   //cameraTaskArgsController := new(controllers.CameraTaskArgsController)
   dicController := new(controllers.DictionaryController)
   userController := new(controllers.UserController)
   eventPushController := new(controllers.EventPushController)
   pollConfigController := new(controllers.PollConfigController)
   fileController := new(controllers.FileController)
   sysMenuController :=new(controllers.SysMenuController)
   clusterController :=new(controllers.ClusterController)
   sysRoleController :=new(controllers.RoleController)
   sysMenuController := new(controllers.SysMenuController)
   clusterController := new(controllers.ClusterController)
   sysRoleController := new(controllers.RoleController)
   ptzController := new(controllers.PanTiltZoomController)
   licenseController := new(controllers.LicenseController)
   fileAnalysisC := new(controllers.FileAnalysisController)
   fileSettingC := new(controllers.FileAnalysisSettingController)
    icController := new(controllers.InfoController)
    gb28181C := new(controllers.Gb28181Controller)
    fStackC := new(controllers.FileStackController)
   cameraRuleController := new (controllers.CameraRuleController)
   rtc := new(controllers.RuleTemplateController)
   voiceC := new(controllers.VoiceController)

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

   sysApi := r.Group(  "/data/api-u/sys")
   licenseApi := r.Group(urlPrefix + "/license")
   {
      sysApi.POST("/login",userController.Login)
      sysApi.GET("/logout",userController.Logout)
      sysApi.POST("refresh_token",userController.RefreshToken)
      licenseApi.POST("/getRegisterCode", licenseController.GetRegisterCode)
      licenseApi.POST("/save", licenseController.Save)
      licenseApi.GET("/show", licenseController.Show)
   }

   sysApi := r.Group("/data/api-u/sys")
   {
      sysApi.POST("/login", userController.Login)
      sysApi.GET("/logout", userController.Logout)
      sysApi.POST("refresh_token", userController.RefreshToken)
   }
   sysMenuApi := r.Group("/data/api-u/sysmenus")
   {
      sysMenuApi.GET("/me",sysMenuController.Me)
      sysMenuApi.GET("/tree",sysMenuController.MenuTree)
      sysMenuApi.GET("/me", sysMenuController.Me)
      sysMenuApi.GET("/tree", sysMenuController.MenuTree)
   }
   roleApi :=r.Group("/data/api-v/role")
   roleApi := r.Group("/data/api-v/role")
   {
      roleApi.GET("/findAll",sysRoleController.FindAll)
      roleApi.GET("/findAll", sysRoleController.FindAll)
   }
   userApi := r.Group("/data/api-u/users")
   {
      userApi.GET("/current",userController.Current)
      userApi.GET("/current", userController.Current)
      userApi.GET("/findAllUser", userController.FindAllUser)
      userApi.POST("/edit",userController.Edit)
      userApi.POST("/findById", userController.FindById)
      userApi.POST("/saveAuth", userController.SaveAuth)
      userApi.POST("/updatePwd", userController.UpdatePwd)
   }

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

   //区域管理
   area := r.Group(urlPrefix + "/area")
   {
      area.GET("/localmenu", areaController.CameraTree)
      area.GET("/gb28181Tree",areaController.CameraGb28181Tree)
      area.GET("/gb28181Tree", areaController.CameraGb28181Tree)
      area.POST("/add", areaController.AreaAdd)
      area.POST("/del", areaController.AreaDelete)
      area.POST("/update", areaController.AreaUpdate)
      area.POST("/gb28181TreeRefresh", areaController.Gb28181TreeRefresh)
      area.POST("/gb28181TreeDelete", areaController.Gb28181TreeDelete)
   }

   gbApi := r.Group(urlPrefix + "/gb28181")
   {
      gbApi.GET("/findAreaByParentId", gb28181C.FindAreaByParentId)
      gbApi.GET("/newGbId", gb28181C.NewGbId)
   }

   //摄像机管理
@@ -86,35 +111,58 @@
      camera.PUT("/update", cameraController.CameraUpdate)
      camera.DELETE("/del/:cid", cameraController.CameraDel)
      camera.GET("/show/:cid", cameraController.CameraSel)
      camera.GET("/updateSnapshotUrl/:cid",cameraController.UpdateSnapshotUrl)
      camera.POST("/updateCameraArea", cameraController.UpdateCameraArea)
      camera.GET("/updateSnapshotUrl/:cid", cameraController.UpdateSnapshotUrl)

      camera.POST("/alltask", cameraTaskController.FindTasksByCameraIds)
      camera.GET("/task/:cameraId", cameraTaskController.CameraTaskAll)
      //camera.GET("/task/:cameraId", cameraTaskController.CameraTaskAll)

      camera.DELETE("/delTask/:cameraId/:taskId", cameraController.CameraDelTask)
      camera.POST("/saveTask", cameraController.CameraTaskSave)
      camera.GET("/getRulesByCameraAndTask", cameraTaskArgsController.FindByCameraAndTask)
      //camera.DELETE("/delTask/:cameraId/:taskId", cameraController.CameraDelTask)
      //camera.POST("/saveTask", cameraController.CameraTaskSave)
      //camera.GET("/getRulesByCameraAndTask", cameraTaskArgsController.FindByCameraAndTask)
      camera.GET("/getCamerasByRunType", cameraController.GetCamerasByRunType)
      camera.POST("/updateRunEnable", cameraController.UpdateRunEnable)
      camera.POST("/changeRunType", cameraController.ChangeRunType)
      camera.GET("/getAllCamerasByServer", cameraController.GetAllCamerasByServer)

      camera.POST("/ptzControl", ptzController.Move)
      camera.GET("/statisticRunInfo", cameraController.StatisticRunInfo)
      camera.POST("/pasteRules", cameraRuleController.PasteRules)
   }

   cameraTaskArgsApi := r.Group(urlPrefix + "/cameraTaskArgs")
   rtcApi := r.Group(urlPrefix + "/template")
   {
      cameraTaskArgsApi.GET("/deleteByGroup", cameraTaskArgsController.DeleteByGroup)
      cameraTaskArgsApi.POST("/getLinkRulesByCameraIds", cameraTaskArgsController.GetLinkRulesByCameraIds)
      cameraTaskArgsApi.POST("/saveLinkRulesByGroup", cameraTaskArgsController.SaveLinkRulesByGroup)
      cameraTaskArgsApi.POST("/updateDefenceStateByGroup",cameraTaskArgsController.UpdateDefenceStateByGroup)
      rtcApi.POST("/rule/save", rtc.Save)
      rtcApi.GET("/rule/:id", rtc.Show)
      rtcApi.DELETE("/rule/:id", rtc.Delete)
      rtcApi.GET("/rule", rtc.FindAll)
   }
   cameraRuleApi :=r.Group(urlPrefix+"/camera/rule")
   {
      cameraRuleApi.GET("/findByCameraId", cameraRuleController.FindByCameraId)
      cameraRuleApi.DELETE("/deleteGroup/:groupId",cameraRuleController.DeleteByGroup)
      cameraRuleApi.POST("/getLinkRulesByCameraIds",cameraRuleController.GetLinkRulesByCameraIds)
      cameraRuleApi.POST("/save", cameraRuleController.Save)
      cameraRuleApi.POST("/saveLinkRulesByGroup",cameraRuleController.SaveLinkRulesByGroup)
   }

   cameraTaskApi := r.Group(urlPrefix + "/cameraTask")
   {
      cameraTaskApi.POST("/saveIsDataTrans", cameraTaskController.SaveIsDataTrans)
      cameraTaskApi.POST("/saveAlarmLevelByGroup", cameraTaskController.SaveAlarmLevelByGroup)
      cameraTaskApi.POST("/updateCameraTaskStatus", cameraTaskController.UpdateCameraTaskStatus)
      cameraTaskApi.POST("/addTask", cameraTaskController.AddTask)
   }
   //cameraTaskArgsApi := r.Group(urlPrefix + "/cameraTaskArgs")
   //{
   //   cameraTaskArgsApi.GET("/deleteByGroup", cameraTaskArgsController.DeleteByGroup)
   //   cameraTaskArgsApi.POST("/getLinkRulesByCameraIds", cameraTaskArgsController.GetLinkRulesByCameraIds)
   //   cameraTaskArgsApi.POST("/saveLinkRulesByGroup", cameraTaskArgsController.SaveLinkRulesByGroup)
   //   cameraTaskArgsApi.POST("/updateDefenceStateByGroup", cameraTaskArgsController.UpdateDefenceStateByGroup)
   //
   //   cameraTaskArgsApi.POST("/ruleApply2All", cameraTaskArgsController.RuleApply2All)
   //}

   //cameraTaskApi := r.Group(urlPrefix + "/cameraTask")
   //{
   //   cameraTaskApi.POST("/saveIsDataTrans", cameraTaskController.SaveIsDataTrans)
   //   cameraTaskApi.POST("/saveAlarmLevelByGroup", cameraTaskController.SaveAlarmLevelByGroup)
   //   cameraTaskApi.POST("/updateCameraTaskStatus", cameraTaskController.UpdateCameraTaskStatus)
   //   cameraTaskApi.POST("/addTask", cameraTaskController.AddTask)
   //}

   polygon := r.Group(urlPrefix + "/polygon")
   {
@@ -128,25 +176,33 @@
   // 任务管理
   task := r.Group(urlPrefix + "/task")
   {
      task.GET("/findAll", taskController.FindAll)
      task.POST("/addTask", taskController.AddTask)
      task.POST("/updateTaskStatus", taskController.UpdateTaskStatus)
      task.GET("/delete", taskController.DeleteTask)
      task.POST("/addTaskSdk", taskController.AddTaskSdk)
      task.GET("/delTaskSdk", taskController.DeleteTaskSdk)
      task.POST("/updateTaskName", taskController.UpdateTaskName)
      task.GET("/getRulesByTaskSdk", taskController.GetRulesByTaskSdk)
      task.POST("/deleteTaskSdkRule", taskController.DeleteTaskSdkRule)
      task.POST("/saveTaskSdkRule", taskController.SaveTaskSdkRule)
      //task.GET("/findAll", taskController.FindAll)
      task.GET("/aggregateTaskList", taskController.AggregateTaskList)
      //task.POST("/addTask", taskController.AddTask)
      //task.POST("/updateTaskStatus", taskController.UpdateTaskStatus)
      //task.GET("/delete", taskController.DeleteTask)
      //task.POST("/addTaskSdk", taskController.AddTaskSdk)
      //task.GET("/delTaskSdk", taskController.DeleteTaskSdk)
      //task.POST("/updateTaskName", taskController.UpdateTaskName)
      //task.GET("/getRulesByTaskSdk", taskController.GetRulesByTaskSdk)
      //task.POST("/deleteTaskSdkRule", taskController.DeleteTaskSdkRule)
      //task.POST("/saveTaskSdkRule", taskController.SaveTaskSdkRule)
      //
      //task.GET("/statisticTaskCamera", taskController.StatisticTaskCamera)
   }

   // 检索 查询
   // 检索 查询 节点操作
   es := r.Group(urlPrefix + "/es")
   {
      es.POST("/tagList", esSearchController.PostEsTagList)
      es.POST("/taskList", esSearchController.PostEsTaskList)
      es.POST("/esSearch", esSearchController.PostEsSearch)
      es.POST("/queryEsCompareData", controllers.PostEsCompareData)
      es.POST("/getEsClusterInfo", esManagementController.GetEsClusterInfo)
      es.POST("/addCluster", esManagementController.AddCluster)
      es.POST("/createNode", esManagementController.CreateNode)
      es.POST("/updateEsHosts", esManagementController.UpdateEsHosts)
      es.POST("/getBuckets", bucketsController.GetBuckets)
   }

   //实时被调数据
@@ -157,6 +213,12 @@
      realTime.POST("/initForCaptureData", realTimeController.InitForCaptureData)
      realTime.POST("/initForMonitoringData", realTimeController.InitForMonitoringData)
   }
   //清理数据
   deleteData := r.Group(urlPrefix + "/clearData")
   {
      deleteData.POST("/deleteEsData", deleteDataController.DeleteEsData)
   }

   //底库 操作
   vdbtable := r.Group(urlPrefix + "/dbtable")
   {
@@ -179,9 +241,15 @@
      vdbperson.PUT("/addDbPerson", dbPersonCont.AddDbPerson)

      vdbperson.POST("/fileUploadTest", fileController.UploadPersonTest)
      vdbperson.POST("/faceExtract",fileController.FaceExtract)
      vdbperson.POST("/searchByPhoto",fileController.SearchByPhoto)
      vdbperson.POST("/faceExtract", fileController.FaceExtract)
      vdbperson.POST("/searchByPhoto", fileController.SearchByPhoto)
      vdbperson.POST("/updateFace", dbPersonCont.UpdateFace)

      vdbperson.POST("/joinDbTable", dbPersonCont.JoinDbTable)
      vdbperson.POST("/move", dbPersonCont.Move)
      vdbperson.POST("/copy", dbPersonCont.Copy)

      vdbperson.POST("/multiUploadCarNo", dbPersonCont.MultiUploadCarNo)
   }

   // 系统设置 操作
@@ -195,6 +263,26 @@
      vsset.POST("/saveDevInfo", ssController.SaveDevInfo)
      vsset.GET("/gb28181ConfigShow", ssController.Gb28181ConfigShow)
      vsset.POST("/gb28181ConfigEdit", ssController.Gb28181ConfigEdit)
      vsset.GET("/clockInfo", ssController.GetClockinfo)
      vsset.POST("/updateClock", ssController.SetSysClock)
      vsset.GET("/ntpTest", ssController.TestNTPServer)
      vsset.GET("/sysinfo", ssController.GetSysInfo)
      vsset.GET("/sysThresholds", ssController.GetSysThresholds)

      vsset.GET("/reboot", ssController.RebootOS)
      vsset.GET("/rebootTask", ssController.GetRebootTask)
      vsset.POST("/rebootTask", ssController.SetRebootTask)

      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)
   }

   ic := r.Group(urlPrefix + "/info")
   {
      ic.GET("/getServerName", icController.GetServerName)
   }

   //算法库操作
@@ -204,11 +292,16 @@
      sdkApi.GET("/findAllSdk", sdkController.FindAllSdk)
      sdkApi.GET("/findByTaskId", sdkController.FindByTaskId)
      sdkApi.GET("/getById", sdkController.GetById)
      sdkApi.GET("/sdkDownload",sdkController.SdkDownLoad)
      sdkApi.GET("/sdkDownload", sdkController.SdkDownLoad)
      sdkApi.GET("/upload", sdkController.Upload)
      sdkApi.POST("/upload", sdkController.UploadPack)
      sdkApi.POST("/showInstallInfo", sdkController.ShowInstallInfo)
      sdkApi.POST("/install", sdkController.Install)
      sdkApi.GET("/active", sdkController.Active)
   }

   //算法参数
   sdkArgApi :=r.Group(urlPrefix + "/sdkArg")
   sdkArgApi := r.Group(urlPrefix + "/sdkArg")
   {
      sdkArgApi.GET("/getSdkArgs", sdkController.GetSdkArgs)
   }
@@ -239,8 +332,9 @@
      pollCApi.POST("/savePollDelay", pollConfigController.SavePollDelay)
      pollCApi.GET("/getPollConfig", pollConfigController.GetPollConfig)
      pollCApi.POST("/updateEnable", pollConfigController.UpdateEnable)
      pollCApi.POST("/updateChannelCount", pollConfigController.UpdateChannelCount)
   }
   clusterApi := r.Group(urlPrefix+"/cluster")
   clusterApi := r.Group(urlPrefix + "/cluster")
   {
      clusterApi.GET("/findCluster", clusterController.FindCluster)
      clusterApi.GET("/randomPwd", clusterController.RandomPwd)
@@ -252,7 +346,36 @@
      clusterApi.POST("/updateClusterName", clusterController.UpdateClusterName)
      clusterApi.POST("/leave", clusterController.Leave)
   }
   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.GET("/findByStackId", fileAnalysisC.FindByStackId)

      fileAnalyApi.POST("/move", fileAnalysisC.Move)
      fileAnalyApi.POST("/rename", fileAnalysisC.Rename)
      fileAnalyApi.POST("/copy", fileAnalysisC.Copy)
   }
   fileSettingApi := r.Group(urlPrefix + "/fileSetting")
   {
      fileSettingApi.GET("/show", fileSettingC.Show)
      fileSettingApi.POST("/changeEnable", fileSettingC.ChangeEnable)
   }

    fStackApi := r.Group(urlPrefix +"/fileStack")
    {
        fStackApi.GET("/findAllByPage",fStackC.FindAllByPage)
        fStackApi.POST("/save",fStackC.Save)
        fStackApi.GET("/show/:id", fStackC.Show)
        fStackApi.POST("/changeEnable", fStackC.ChangeEnable)
        fStackApi.DELETE("/delete/:id", fStackC.Delete)
    }
   voiceApi := r.Group(urlPrefix + "/voice")
   {
      voiceApi.GET("/findAll", voiceC.FindAll)
   }
   // 文件 上传
   r.Static("static", "./static") // 静态文件
   //外部访问swagger.json