| | |
|---|
| | | // @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{} { |
|---|
| | | //请求索引 |
|---|
