package com.boying.service;
|
|
import com.boying.entity.VideoRecordDto;
|
import com.boying.service.HCNetSDK;
|
import com.boying.service.SdkInitService;
|
import com.sun.jna.ptr.IntByReference;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.data.redis.core.RedisTemplate;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Timer;
|
|
@Component
|
public class VideoJob {
|
|
@Autowired
|
private RedisTemplate redisTemplate;
|
@Value("${allFilePath.videoPath}")
|
private String videoPath;
|
private Boolean runFlag = false;
|
private String VIDEO_EQ_KEY="VIDEO_EQ_KEY:";
|
int lUserID;
|
int m_lLoadHandle;
|
Timer downloadtimer;//下载用定时器
|
private static HCNetSDK hCNetSDK = SdkInitService.hcNetSDK;
|
@Scheduled(cron = "0/1 * * * * *")
|
public void work() throws InterruptedException {
|
if(runFlag){
|
return;
|
}
|
VideoRecordDto videoRecordDto = (VideoRecordDto) redisTemplate.boundListOps(VIDEO_EQ_KEY).rightPop();
|
if(videoRecordDto == null){
|
return;
|
}
|
String loginStatus = (String)redisTemplate.opsForValue().get("Login_Status:"+videoRecordDto.getDiskUrl());
|
if("true".equals(loginStatus)){
|
return;
|
}
|
if(videoRecordDto != null){
|
try {
|
runFlag = true;
|
redisTemplate.opsForValue().set("Login_Status:"+videoRecordDto.getDiskUrl(),"true");
|
HCNetSDK.NET_DVR_DEVICEINFO_V30 m_strDeviceInfo = new HCNetSDK.NET_DVR_DEVICEINFO_V30();
|
lUserID = hCNetSDK.NET_DVR_Login_V30(videoRecordDto.getDiskUrl(),(short)8000,videoRecordDto.getDiskUser(),videoRecordDto.getDiskPassword(), m_strDeviceInfo);
|
long userID = lUserID;
|
if (userID == -1) {
|
System.out.println("hksdk(视频)-海康sdk登录失败!");
|
return;
|
}
|
dowmloadRecordByTime(lUserID,videoRecordDto);
|
Thread.sleep(0);
|
}catch (Exception e){
|
runFlag = false;
|
}finally {
|
runFlag = false;
|
redisTemplate.opsForValue().set("Login_Status:"+videoRecordDto.getDiskUrl(),"false");
|
}
|
}
|
|
}
|
|
//按时间下载录像(不支持转码3GP格式)
|
public void dowmloadRecordByTime(int userID,VideoRecordDto dto)
|
{
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
String start = sdf.format(dto.getStartTime());
|
String end = sdf.format(dto.getEndTime());
|
List<Integer> startList = getDateString(start);
|
List<Integer> endList = getDateString(end);
|
HCNetSDK.NET_DVR_PLAYCOND net_dvr_playcond = new HCNetSDK.NET_DVR_PLAYCOND();
|
net_dvr_playcond.read();
|
net_dvr_playcond.dwChannel=dto.getEqPort(); //通道号 NVR设备路数小于32路的起始通道号从33开始，依次增加
|
//开始时间
|
net_dvr_playcond.struStartTime.dwYear=startList.get(0);
|
net_dvr_playcond.struStartTime.dwMonth=startList.get(1);
|
net_dvr_playcond.struStartTime.dwDay=startList.get(2);
|
net_dvr_playcond.struStartTime.dwHour=startList.get(3);
|
net_dvr_playcond.struStartTime.dwMinute=startList.get(4);
|
net_dvr_playcond.struStartTime.dwSecond=startList.get(5);
|
//停止时间
|
net_dvr_playcond.struStopTime.dwYear=endList.get(0);
|
net_dvr_playcond.struStopTime.dwMonth=endList.get(1);
|
net_dvr_playcond.struStopTime.dwDay=endList.get(2);
|
net_dvr_playcond.struStopTime.dwHour=endList.get(3);
|
net_dvr_playcond.struStopTime.dwMinute=endList.get(4);
|
net_dvr_playcond.struStopTime.dwSecond=endList.get(5);
|
net_dvr_playcond.write();
|
HCNetSDK.NET_DVR_FINDDATA_V40 struFindData = new HCNetSDK.NET_DVR_FINDDATA_V40();
|
struFindData.read();
|
String strFileName = null;
|
try {
|
strFileName=new String(struFindData.sFileName,"UTF-8").trim();
|
}catch (Exception e){
|
e.printStackTrace();
|
}
|
String sFileName = videoPath+dto.getVideoName();
|
System.out.println(sFileName);
|
//m_lLoadHandle=hCNetSDK.NET_DVR_GetFileByName(userID,strFileName,sFileName.getBytes());
|
|
m_lLoadHandle = hCNetSDK.NET_DVR_GetFileByTime_V40(userID,sFileName,net_dvr_playcond);
|
if (m_lLoadHandle >= 0)
|
{
|
hCNetSDK.NET_DVR_PlayBackControl(m_lLoadHandle, HCNetSDK.NET_DVR_PLAYSTART, 0, null);
|
|
/* IntByReference intP=new IntByReference(5*8*1024);
|
IntByReference intInlen=new IntByReference(0);
|
boolean b_PlayBack=ClientDemo.hCNetSDK.NET_DVR_PlayBackControl_V40(m_lLoadHandle,24,intP.getPointer(),4,Pointer.NULL,intInlen);
|
if (!b_PlayBack) {
|
System.out.println("设置下载速度失败，错误码为" + ClientDemo.hCNetSDK.NET_DVR_GetLastError());
|
return;
|
}*/
|
Date nowTime = new Date(System.currentTimeMillis());
|
SimpleDateFormat sdFormatter = new SimpleDateFormat("yyyy-MM-dd-hh-mm-ss");
|
System.out.println("开始下载时间："+sdFormatter.format(nowTime));
|
downloadtimer = new Timer();//新建定时器
|
downloadtimer.schedule(new downloadTask(), 0, 5000);//0秒后开始响应函数
|
} else
|
{
|
System.out.println("按时间下载失败");
|
System.out.println("laste error " + hCNetSDK.NET_DVR_GetLastError());
|
return;
|
}
|
}
|
|
class downloadTask extends java.util.TimerTask
|
{
|
//定时器函数
|
@Override
|
public void run()
|
{
|
|
IntByReference nPos = new IntByReference(0);
|
hCNetSDK.NET_DVR_PlayBackControl(m_lLoadHandle, HCNetSDK.NET_DVR_PLAYGETPOS, 0, nPos);
|
if (nPos.getValue() > 100)
|
{
|
m_lLoadHandle=-1;
|
downloadtimer.cancel();
|
System.out.println( "由于网络原因或DVR忙,下载异常终止!");
|
}
|
if (nPos.getValue() == 100)
|
{
|
Date nowTime = new Date(System.currentTimeMillis());
|
SimpleDateFormat sdFormatter = new SimpleDateFormat("yyyy-MM-dd-hh-mm-ss");
|
System.out.println("结束下载时间："+sdFormatter.format(nowTime));
|
m_lLoadHandle=-1;
|
downloadtimer.cancel();
|
System.out.println("按时间下载结束!");
|
//退出程序时调用，每一台设备分别注销
|
if (hCNetSDK.NET_DVR_Logout(lUserID)) {
|
System.out.println("注销成功");
|
}
|
// hCNetSDK.NET_DVR_Cleanup();
|
}
|
}
|
}
|
|
static List<Integer> getDateString(String dateString){
|
String[] s = dateString.split(" ");
|
List<Integer> list = new ArrayList<>();
|
for (int i = 0; i < s.length; i++) {
|
String s1 = s[i];
|
if(i==0){
|
for (String s2 : s1.split("-")) {
|
list.add(Integer.parseInt(s2));
|
}
|
}else {
|
for (String s2 : s1.split(":")) {
|
list.add(Integer.parseInt(s2));
|
}
|
}
|
}
|
return list;
|
}
|
|
public static void main(String[] args) {
|
getDateString("2024-07-04 09:37:00");
|
}
|
|
}
|
