package com.ruoyi.quartz.task;
|
|
|
import com.ruoyi.common.core.domain.AjaxResult;
|
import com.ruoyi.common.core.domain.entity.SysUser;
|
import com.ruoyi.common.utils.uuid.IdUtils;
|
import com.ruoyi.device.camera.domain.ArdCameras;
|
import com.ruoyi.device.camera.domain.CameraCmd;
|
import com.ruoyi.device.camera.factory.CameraSDK;
|
import com.ruoyi.device.camera.factory.CameraSDKFactory;
|
import com.ruoyi.device.camera.service.IArdCamerasService;
|
import com.ruoyi.device.camera.service.ICameraSdkService;
|
import com.ruoyi.device.channel.domain.ArdChannel;
|
import com.ruoyi.device.channel.service.IArdChannelService;
|
import com.ruoyi.device.channel.service.impl.ArdChannelServiceImpl;
|
import com.ruoyi.media.domain.Vtdu;
|
import com.ruoyi.media.service.IMediaService;
|
import com.ruoyi.media.service.IVtduService;
|
import com.ruoyi.rongcloud.service.RongCloudService;
|
import com.ruoyi.system.service.ISysUserService;
|
import com.ruoyi.utils.sdk.common.GlobalVariable;
|
import com.ruoyi.utils.sdk.dhsdk.service.impl.DahuaSDK;
|
import com.ruoyi.utils.sdk.hiksdk.service.impl.HikvisionSDK;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
import java.util.List;
|
import java.util.UUID;
|
import java.util.stream.Collectors;
|
|
/**
|
* @Description: 同步任务
|
* @ClassName: syncDeviceStateTask
|
* @Author: 刘苏义
|
* @Date: 2023年10月08日11:06:42
|
**/
|
@Component("SyncTask")
|
@Slf4j
|
public class SyncTask {
|
@Resource
|
ISysUserService sysUserService;
|
@Resource
|
RongCloudService rongCloudService;
|
@Resource
|
IArdCamerasService iArdCamerasService;
|
@Resource
|
IVtduService vtduService;
|
@Resource
|
IMediaService mediaService;
|
@Resource
|
private ICameraSdkService cameraSdkService;
|
@Resource
|
private CameraSDKFactory cameraSDKFactory;
|
@Resource
|
private IArdChannelService ardChannelService;
|
|
/**
|
* 同步相机在线状态
|
* 刘苏义
|
* 2023/10/8 14:54:41
|
*/
|
public void cameraState() {
|
try {
|
ArdCameras ardCamera = new ArdCameras();
|
//调用查询方法
|
List<ArdCameras> ardCameras = iArdCamerasService.selectArdCamerasListNoDataScope(ardCamera);
|
for (ArdCameras camera : ardCameras) {
|
CameraCmd cmd = new CameraCmd();
|
cmd.setCameraId(camera.getId());
|
boolean onLineNew = cameraSdkService.isOnLine(cmd);
|
boolean onLineOld = "1".equals(camera.getState());
|
if (onLineNew != onLineOld) {
|
if (onLineNew) {
|
camera.setState("1");
|
} else {
|
camera.setState("0");
|
}
|
iArdCamerasService.updateArdCameras(camera);
|
}
|
}
|
} catch (Exception ex) {
|
log.error("同步相机在线状态异常:" + ex.getMessage());
|
}
|
}
|
|
/**
|
* @Author 刘苏义
|
* @Description 同步通道状态实时同步流媒体
|
* @Date 2024/7/9 16:01
|
*/
|
public void syncChannelState(){
|
log.debug("定时同步通道任务开始");
|
//获取所有nvr设备
|
List<ArdCameras> ardCamerasList = GlobalVariable.loginedSet.stream().collect(Collectors.toList());
|
if (ardCamerasList.size() > 0) {
|
ardCamerasList.stream()
|
.forEach(ardCameras -> {
|
if (ardCameras.getLoginId() > 0) {
|
//通过SDK获取NVR实际通道
|
CameraSDK cameraSDK = cameraSDKFactory.createCameraSDK(ardCameras.getFactory());
|
List<ArdChannel> ardChannelList = cameraSDK.getChannels(ardCameras);
|
//同步通道表
|
ArdChannel ardChannel = new ArdChannel();
|
ardChannel.setDeviceId(ardCameras.getId());
|
List<ArdChannel> ardChannelListDb = ardChannelService.selectArdChannelList(ardChannel);
|
ardChannelService.asyncChannel(ardCameras, ardChannelListDb, ardChannelList);
|
}
|
});
|
}
|
}
|
|
/**
|
* 定时获取app用户在线状态
|
* 刘苏义
|
* 2023/8/9 9:17:48
|
*/
|
public void appUserState() {
|
try {
|
List<SysUser> SysUserList = sysUserService.selectAllAppUserList(new SysUser());
|
if (SysUserList.size() > 0) {
|
for (SysUser sysUser : SysUserList) {
|
String state = sysUser.getAppOnlineState();//获取当前用户的在线状态
|
Boolean online = rongCloudService.checkOnline(sysUser.getUserId());//从融云获取在线状态
|
if (state != null) {
|
Boolean appOnlineState = state.equals("1");
|
if (appOnlineState == online) {
|
continue;
|
}
|
}
|
sysUser.setAppOnlineState(online ? "1" : "0");
|
sysUserService.updateUserProfile(sysUser);
|
}
|
}
|
} catch (Exception ex) {
|
log.error("融云在线接口异常：" + ex.getMessage());
|
}
|
}
|
|
/**
|
* 同步流媒体
|
* 刘苏义
|
* 2023/10/13 14:13:53
|
*/
|
public void syncVtdu() {
|
log.debug("定时同步流媒体任务开始");
|
List<String> nameList = mediaService.getNameList();
|
List<Vtdu> vtduList = vtduService.selectVtduList(new Vtdu());
|
vtduService.asyncVtdu(vtduList, nameList);
|
}
|
}
|
