rm nouse method

liuxiaolong

2019-07-02 53f2a1ea4ef030f9f4ba2f5faced661ea39a9755

rm nouse method

 controllers/es.go

@@ -117,47 +117,47 @@
// @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/queryCameraAndTaskInfo [get]
func (ac *CameraController) QueryCameraAndTaskInfo(c *gin.Context) {
    var cam models.Camera
    rows := cam.FindAllCamTask()

    if len(rows) == 0 {
        util.ResponseFormat(c, code.ComError, "没有记录")
        return
    }
    camList := make([]map[string]interface{}, 0, 5)
    for _, cam := range rows {
        newCam := make(map[string]interface{})
        newCam["cameraid"] = cam.Id
        newCam["rtspUrl"] = cam.Rtsp
        tasks := cam.CamTask
        taskList := make([]map[string]interface{}, 0)
        if tasks != nil {
            taskmap := make(map[string]interface{})
            for _, task := range tasks {
                taskId := taskmap[task.Taskid]
                if taskId != nil {
                    cameraTasks := taskmap[task.Taskid].([]models.CameraTask)
                    cameraTasks = append(cameraTasks, task)
                    taskmap[task.Taskid] = cameraTasks
                } else {
                    cameraTasks := make([]models.CameraTask, 0)
                    taskmap[task.Taskid] = append(cameraTasks, task)
                }
            }
            for key, value := range taskmap {
                i := make(map[string]interface{})
                i["taskid"] = key
                i["sdklist"] = value
                taskList = append(taskList, i)
            }
        }
        newCam["tasklist"] = taskList
        camList = append(camList, newCam)
    }
    c.JSON(200, camList)

}
//func (ac *CameraController) QueryCameraAndTaskInfo(c *gin.Context) {
//    var cam models.Camera
//    rows := cam.FindAllCamTask()
//
//    if len(rows) == 0 {
//        util.ResponseFormat(c, code.ComError, "没有记录")
//        return
//    }
//    camList := make([]map[string]interface{}, 0, 5)
//    for _, cam := range rows {
//        newCam := make(map[string]interface{})
//        newCam["cameraid"] = cam.Id
//        newCam["rtspUrl"] = cam.Rtsp
//        tasks := cam.CamTask
//        taskList := make([]map[string]interface{}, 0)
//        if tasks != nil {
//            taskmap := make(map[string]interface{})
//            for _, task := range tasks {
//                taskId := taskmap[task.Taskid]
//                if taskId != nil {
//                    cameraTasks := taskmap[task.Taskid].([]models.CameraTask)
//                    cameraTasks = append(cameraTasks, task)
//                    taskmap[task.Taskid] = cameraTasks
//                } else {
//                    cameraTasks := make([]models.CameraTask, 0)
//                    taskmap[task.Taskid] = append(cameraTasks, task)
//                }
//            }
//            for key, value := range taskmap {
//                i := make(map[string]interface{})
//                i["taskid"] = key
//                i["sdklist"] = value
//                taskList = append(taskList, i)
//            }
//        }
//        newCam["tasklist"] = taskList
//        camList = append(camList, newCam)
//    }
//    c.JSON(200, camList)
//
//}

func searchEsData(searchBody models.EsSearch) map[string]interface{} {
    //请求索引

 models/task.go

@@ -1,8 +1,8 @@
package models

// 关联查询全部摄像机
func (camera *Camera) FindAllCamTask() (cams []Camera) {
    var cameras []Camera
    db.Preload("CamTask").Find(&cameras) //查询所有device记录   // .Preload("CamTask")
    return cameras
}
//func (camera *Camera) FindAllCamTask() (cams []Camera) {
//    var cameras []Camera
//    db.Preload("CamTask").Find(&cameras) //查询所有device记录   // .Preload("CamTask")
//    return cameras
//}

 router/router.go

@@ -72,7 +72,6 @@
        camera.DELETE("/del/:cid", cameraController.CameraDel)
        camera.GET("/show/:cid", cameraController.CameraSel)
        camera.GET("/updateSnapshotUrl/:cid",cameraController.UpdateSnapshotUrl)
        camera.GET("/queryCameraAndTaskInfo", cameraController.QueryCameraAndTaskInfo)

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