package com.ld.igds.timer;
|
|
import com.bstek.dorado.annotation.Expose;
|
import com.ld.igds.camera.ApiCameraManager;
|
import com.ld.igds.camera.CameraUtil;
|
import com.ld.igds.camera.data.ApiCameraResp;
|
import com.ld.igds.camera.data.ApiSnapReq;
|
import com.ld.igds.data.ConfigData;
|
import com.ld.igds.file.CoreFileService;
|
import com.ld.igds.models.SecCamera;
|
import com.ld.igds.models.SecSnapConf;
|
import com.ld.igds.models.SnapSer;
|
import com.ld.igds.sec.service.CoreSecCameraService;
|
import com.ld.igds.sec.service.SecSnapDepotService;
|
import com.ld.igds.util.ContextUtil;
|
import com.ld.igds.util.DateUtil;
|
import com.ld.igds.view.service.SnapSerService;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* 安防模块标定时器配置
|
*/
|
@Slf4j
|
@Component(ScheduledSec.BEAN_ID)
|
public class ScheduledSec {
|
|
public static final String BEAN_ID = "sec.scheduled";
|
|
@Resource
|
private ConfigData configData;
|
@Resource
|
private SecSnapDepotService secSnapService;
|
@Resource
|
private CoreSecCameraService coreSecCameraService;
|
@Resource
|
private SnapSerService snapSerService;
|
@Resource
|
private CoreFileService fileService;
|
@Resource
|
private ApiCameraManager apiCameraManager;
|
|
/**
|
* 从6-18点开始执行
|
*/
|
@Scheduled(cron = "0 0 6,7,8,9,10,11,12,13,14,15,16,17,18 * * ? ")
|
public void scheduled30() {
|
|
Date exeDate = new Date();
|
|
// 执行抓拍判断
|
doExeSnap(exeDate,false);
|
}
|
|
|
/**
|
* sec.scheduled#exeByHand
|
* 手动执行
|
*/
|
@Expose
|
public void exeByHand(){
|
Date exeDate = new Date();
|
|
// 执行抓拍判断
|
doExeSnap(exeDate,true);
|
}
|
|
/**
|
* 定时执行抓拍
|
*/
|
private void doExeSnap(Date date,boolean isByHand) {
|
try {
|
// 获取所有配置抓拍摄像头
|
List<SecSnapConf> list = secSnapService.listSnapConf(
|
configData.getDefaultCompanyId(), null);
|
|
if (null == list || list.isEmpty()) {
|
return;
|
}
|
SecSnapConf exeConf = list.get(0);
|
|
// 获取抓拍时间
|
int exeHour1 = exeConf.getActHour1();
|
int exeHour2 = exeConf.getActHour2();
|
int exeHour3 = exeConf.getActHour3();
|
|
if (exeHour1 == 0 && exeHour1 == 0 && exeHour1 == 0)
|
return;
|
|
// 获取当前系统时间
|
int curHour = DateUtil.getHour(date);
|
|
if(isByHand){
|
exeHour1 = curHour;
|
}
|
|
if(curHour != exeHour1 && curHour != exeHour2 && curHour !=exeHour3){
|
return;
|
}
|
|
log.info("===================执行定时仓内视频抓拍==================");
|
|
SecCamera secCamera;
|
Map<String, SnapSer> snapSerMap = new HashMap<>();
|
SnapSer snapSer;
|
for (SecSnapConf snapConf : list) {
|
|
secCamera = coreSecCameraService.getCameraById(
|
snapConf.getCompanyId(), snapConf.getCameraId());
|
|
if (null == secCamera) continue;
|
|
snapSer = snapSerMap.get(snapConf.getDeptId());
|
if (null == snapSer) {
|
snapSer = snapSerService.getCacheByDeptId(snapConf.getDeptId());
|
snapSerMap.put(snapConf.getDeptId(), snapSer);
|
}
|
|
if (null == snapSer) {
|
log.error("------------抓拍为配置抓拍分机----------");
|
continue;
|
}
|
|
doExeSnapToData(secCamera, snapSer, snapConf);
|
|
Thread.sleep(500);
|
}
|
} catch (Exception e) {
|
log.error("----------抓拍后台出错---------{}", e);
|
}
|
}
|
|
private void doExeSnapToData(SecCamera secCamera, SnapSer snapSer,SecSnapConf snapConf) {
|
ApiSnapReq req = new ApiSnapReq();
|
req.setCompanyId(secCamera.getCompanyId());
|
req.setDeptId(secCamera.getDeptId());
|
req.setSn(secCamera.getSn());
|
req.setSnapType(secCamera.getSnapType());
|
req.setPlayType(secCamera.getPlayType());
|
req.setSerSn(snapSer.getSn());
|
req.setCameraName(secCamera.getName());
|
req.setBizId(null);
|
|
req.setMediaAddr(CameraUtil.updateMediaAddr(secCamera.getMediaAddr(),
|
secCamera.getLoginId(), secCamera.getPwd(),
|
secCamera.getIpIn(), secCamera.getPortInC(),
|
secCamera.getChanNum()));
|
|
String filePath = fileService.getSnapFilePath(new Date());
|
|
req.setFilePath(filePath);
|
|
// 调整附件名称，避免出现中文
|
String fileName = snapConf.getDepotId() + "_" + ContextUtil.getTimeId(1000) + ".jpg";
|
req.setFileName(fileName);
|
|
// 执行抓拍
|
ApiCameraResp resp = apiCameraManager.getApiCameraService(secCamera.getPlayType()).snapImg(req);
|
resp.setFileName(fileName);
|
|
// 执行记录保存
|
secSnapService.addData(snapConf, fileName, resp.getCode());
|
}
|
}
|
