lc_veterans/app/security/service/securityService.go

package service

import (
	"iot_manager_service/app/device/service"
	"iot_manager_service/app/security/model"
	"iot_manager_service/util/cache"
	"iot_manager_service/util/common"
)

var SecurityService = new(securityService)

type securityService struct{}

func (s *securityService) GetCameraLiveList(tenantId int) ([]model.CameraLiveDetail, *common.Errors) {
	groups, err := service.LampPoleGroupService.GetList(tenantId)
	if err != nil {
		return nil, nil
	}

	var rsp []model.CameraLiveDetail
	for _, group := range groups {
		cameraDevices := service.CameraService.GetByLampPoleGroup(group.ID)
		var cameraList []model.CameraLive
		for _, cameraDevice := range cameraDevices {
			_, state := cache.GetDeviceState(cameraDevice.DeviceSN)
			poleGroupName := cameraDevice.DeviceName + "(离线)"
			if state == "1" {
				poleGroupName = cameraDevice.DeviceName + "在线"
			}
			cameraList = append(cameraList, model.CameraLive{
				Id:             cameraDevice.ID,
				DeviceName:     cameraDevice.DeviceName,
				DeviceSn:       cameraDevice.DeviceSN,
				PoleGroupName:  poleGroupName,
				MonitorAddress: cameraDevice.MonitorAddress,
				StreamId:       cameraDevice.StreamId,
				RunState:       state,
			})
		}
		rsp = append(rsp, model.CameraLiveDetail{
			PoleGroupName: group.PoleGroupName,
			CameraList:    cameraList,
		})
	}
	return rsp, nil
}