camera show return runServerName

liuxiaolong

2019-11-02 de0be9f4ffb94c8bca74a7da3174e50d93782540

 controllers/camera.go

@@ -123,8 +123,8 @@
// @Produce json
// @Tags camera
// @Param cid path string true "摄像机id"
// @Success 200 {string} json "{"code":200, success:true,  msg:"请求处理成功", data:"摄像机信息"}"
// @Failure 500 {string} json "{"code":500, success:false   msg:"",data:"错误信息内容"}"
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
// @Failure 500 {string} json "{"code":500, success:false, msg:"",data:""}"
// @Router /data/api-v/camera/show/{cid} [get]
func (ac CameraController) CameraSel(c *gin.Context) {
   var api dbapi.CameraApi
@@ -134,8 +134,35 @@
      util.ResponseFormat(c, code.ComError, "查询失败")
      return
   }

   util.ResponseFormat(c, code.Success, camera)
   //2019-11-02新增需求，显示每个摄像机的处理服务器信息,归属的节点服务器名称
   m := util.Struct2Map(camera)
   m["runServerName"] = ""
   if camera.RunServerId !="" {
      localConf, e := cache.GetServerInfo()
      if e ==nil {
         if camera.RunServerId == localConf.ServerId {//归属本台服务器
            m["runServerName"] = localConf.ServerName
         } else {//属于其他服务器
            var clusterApi dbapi.ClusterApi
            b, data := clusterApi.FindCluster()
            if b && data !=nil {
               cb, _ := json.Marshal(data)
               var clu ClusterDb
               if err := json.Unmarshal(cb, &clu);err ==nil {
                  if len(clu.Nodes) >0 {
                     for _,n :=range clu.Nodes {
                        if camera.RunServerId == n.NodeId {
                           m["runServerName"] = n.NodeName
                           break
                        }
                     }
                  }
               }
            }
         }
      }
   }
   util.ResponseFormat(c, code.Success, m)

}