|
|
@@ -4,9 +4,11 @@ package com.ozs.web.core.util;
|
|
|
import com.alibaba.fastjson2.JSON;
|
|
|
import com.ozs.common.config.BaseConfig;
|
|
|
import com.ozs.common.constant.Constants;
|
|
|
+import com.ozs.common.core.domain.entity.SysDictData;
|
|
|
import com.ozs.common.exception.base.BaseException;
|
|
|
import com.ozs.common.utils.DateUtils;
|
|
|
import com.ozs.common.utils.http.HttpUtils;
|
|
|
+import com.ozs.system.mapper.SysDictDataMapper;
|
|
|
import com.ozs.web.core.config.CaneraConfig;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.apache.commons.lang3.StringUtils;
|
|
|
@@ -32,11 +34,14 @@ public class CameraUtil {
|
|
|
private static String historyUrl;
|
|
|
private static String ffmpegPath;
|
|
|
private static String filePath;
|
|
|
+ private static String transcribeFilePath;
|
|
|
private static String webUrl;
|
|
|
private static String bakUrl;
|
|
|
|
|
|
@Autowired
|
|
|
private CaneraConfig caneraConfig;
|
|
|
+ @Autowired
|
|
|
+ private SysDictDataMapper dictDataMapper;
|
|
|
|
|
|
|
|
|
/**
|
|
|
@@ -211,8 +216,9 @@ public class CameraUtil {
|
|
|
|
|
|
/**
|
|
|
* 合并视频（转化文件）
|
|
|
+ *
|
|
|
* @param fromVideoFileList 视频路径
|
|
|
- * @param newfilePath 生产新的视频文件路径
|
|
|
+ * @param newfilePath 生产新的视频文件路径
|
|
|
* @throws IOException
|
|
|
*/
|
|
|
public static void myConvetor(List<String> fromVideoFileList,
|
|
|
@@ -320,6 +326,7 @@ public class CameraUtil {
|
|
|
historyUrl = caneraConfig.getHistoryUrl();
|
|
|
ffmpegPath = caneraConfig.getFfmpegPath();
|
|
|
filePath = caneraConfig.getFilePath();
|
|
|
+ transcribeFilePath = caneraConfig.getTranscribeFilePath();
|
|
|
webUrl = caneraConfig.getWebUrl();
|
|
|
bakUrl = caneraConfig.getBakUrl();
|
|
|
}
|
|
|
@@ -368,4 +375,74 @@ public class CameraUtil {
|
|
|
}
|
|
|
|
|
|
|
|
|
+ /**
|
|
|
+ * 定时任务：删除超过配置时长的录制视频
|
|
|
+ *
|
|
|
+ * @throws IOException
|
|
|
+ * @throws InterruptedException
|
|
|
+ */
|
|
|
+ public void deleteFlvExceed() throws IOException, InterruptedException {
|
|
|
+ //字典中设置的值
|
|
|
+ List<SysDictData> sysCameraRecordTime = dictDataMapper.selectDictDataByType("sys_camera_record_time");
|
|
|
+ //开启流
|
|
|
+ List<String> rspList = new ArrayList<String>();
|
|
|
+ Process proc = Runtime.getRuntime().exec(transcribeFilePath, null, null);
|
|
|
+ BufferedReader in = new BufferedReader(new InputStreamReader(proc.getInputStream()));
|
|
|
+ PrintWriter out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(proc.getOutputStream())), true);
|
|
|
+
|
|
|
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd");
|
|
|
+ Date date = new Date();
|
|
|
+ Calendar calendar = new GregorianCalendar();
|
|
|
+ calendar.setTime(date);
|
|
|
+ //正数，日期天数加
|
|
|
+ //负数，日期天数减 提前45天
|
|
|
+ if (!ObjectUtils.isEmpty(sysCameraRecordTime)) {
|
|
|
+ String dictValue = sysCameraRecordTime.get(0).getDictValue();
|
|
|
+ calendar.add(Calendar.DAY_OF_YEAR, Integer.parseInt("-" + dictValue));
|
|
|
+ } else {
|
|
|
+ calendar.add(Calendar.DAY_OF_YEAR, -45);
|
|
|
+ }
|
|
|
+ date = calendar.getTime();
|
|
|
+ //时间格式化为字符串
|
|
|
+ String formatD = sdf.format(date);
|
|
|
+ //遍历每个进行视频录制的摄像头
|
|
|
+ File file = new File(transcribeFilePath);
|
|
|
+ if (file.exists()) {
|
|
|
+ String s = HttpUtils.sendGet(transcribeFilePath, null);
|
|
|
+ if (!StringUtils.isBlank(s) || "null".equals(s)) {
|
|
|
+ List<Map<String, Object>> maps = JSON.parseArray(s, Map.class);
|
|
|
+ if (ObjectUtils.isEmpty(maps)) {
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ List<String> commands = new ArrayList<>();
|
|
|
+ for (Map<String, Object> map : maps) {
|
|
|
+ Object path = map.get("Path");
|
|
|
+ ////查出符合条件的视频文件，删掉
|
|
|
+ //if (!ObjectUtils.isEmpty(path)) {
|
|
|
+ // String commit = " rm -rf " + transcribeFilePath + formatD + "*";
|
|
|
+ // commands.add(commit);
|
|
|
+ //}
|
|
|
+ }
|
|
|
+ // 删除
|
|
|
+ for (String line : commands) {
|
|
|
+ out.println(line);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ // 这个命令必须执行，否则in流不结束。
|
|
|
+ out.println("exit");
|
|
|
+ String rspLine = "";
|
|
|
+ while ((rspLine = in.readLine()) != null) {
|
|
|
+ System.out.println(rspLine);
|
|
|
+ rspList.add(rspLine);
|
|
|
+ }
|
|
|
+ int i = proc.waitFor();
|
|
|
+ log.info("执行结果：{}", i);
|
|
|
+ //关闭流
|
|
|
+ in.close();
|
|
|
+ out.close();
|
|
|
+ proc.destroy();
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
}
|
