package com.ard.work.device.camera.service.impl;
|
|
import com.ard.common.core.constant.CacheConstants;
|
import com.ard.work.api.domian.ArdCamera;
|
import com.ard.work.api.domian.ArdCameraHepu;
|
import com.ard.work.api.domian.ArdChannel;
|
import com.ard.work.device.camera.mapper.ArdCameraHepuMapper;
|
import com.ard.work.device.camera.service.IArdCameraHepuService;
|
import com.ard.work.event.HepuLoginEvent;
|
import com.ard.work.event.LoginEvent;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.context.event.EventListener;
|
import org.springframework.scheduling.annotation.Async;
|
import org.springframework.stereotype.Service;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.stream.Collectors;
|
|
@Slf4j
|
@Service
|
public class ArdCameraHepuServiceImpl implements IArdCameraHepuService {
|
|
@Autowired
|
private ArdCameraHepuMapper ardCameraHepuMapper;
|
|
@Override
|
public ArdCameraHepu selectArdCameraHepuById(String id) {
|
return ardCameraHepuMapper.selectArdCameraHepuById(id);
|
}
|
|
@Override
|
public List<ArdCameraHepu> selectByCameraId(String cameraId) {
|
return ardCameraHepuMapper.selectByCameraId(cameraId);
|
}
|
|
@Override
|
public List<ArdCameraHepu> selectArdCameraHepuList(ArdCameraHepu ardCameraHepu) {
|
return ardCameraHepuMapper.selectArdCameraHepuList(ardCameraHepu);
|
}
|
|
@Override
|
public int insertArdCameraHepu(ArdCameraHepu ardCameraHepu) {
|
return ardCameraHepuMapper.insertArdCameraHepu(ardCameraHepu);
|
}
|
|
@Override
|
public int batchInsertArdCameraHepu(List<ArdCameraHepu> list) {
|
if (list == null || list.isEmpty()) {
|
return 0;
|
}
|
// 调用 Mapper 层的批量插入方法
|
return ardCameraHepuMapper.batchInsertArdCameraHepu(list);
|
}
|
|
@Override
|
public int updateArdCameraHepu(ArdCameraHepu ardCameraHepu) {
|
return ardCameraHepuMapper.updateArdCameraHepu(ardCameraHepu);
|
}
|
|
|
@Override
|
public int deleteArdCameraHepuById(String id) {
|
return ardCameraHepuMapper.deleteArdCameraHepuById(id);
|
}
|
|
@Override
|
public int deleteArdCameraHepuByIds(String[] ids) {
|
return ardCameraHepuMapper.deleteArdCameraHepuByIds(ids);
|
}
|
|
@Override
|
public int deleteByCameraId(String cameraId) {
|
return ardCameraHepuMapper.deleteByCameraId(cameraId);
|
}
|
|
|
/**
|
* 监听登录事件
|
*
|
* @param loginEvent 登录事件
|
* @author 刘苏义
|
* @date 2024/8/23 15:42
|
*/
|
@Async
|
@EventListener(HepuLoginEvent.class)
|
public void LoginEventListener(HepuLoginEvent loginEvent) {
|
ArdCameraHepu node = loginEvent.getCamera();
|
// 更新节点信息
|
ardCameraHepuMapper.updateArdCameraHepu(node);
|
}
|
}
|
