Merge branch 'dev'

王言钊
2 parents 6b7eaf73 6e99e8e5
Showing 2 changed files with 64 additions and 3 deletions
src/main/java/com/cnlive/shenhe/api/VideosControllerApi.java
src/main/java/com/cnlive/shenhe/job/TextJob.java
@@ -179,11 +179,11 @@ public class VideosControllerApi {
                 }
                 //如果审核类型是机审
             } else if (shyVideos1.getShenhe_type() == CommonConst.AUDIT_TYPE_MACHANE) {
-                //"目击者"视频，小于60秒的抽帧
-                if (CommonUtils.isNotNull(duration) && duration < 60) {
+                //"目击者"视频，小于300秒的抽帧
+                if (CommonUtils.isNotNull(duration) && duration < 300) {
                     shyVideos1 = avsample(shyVideos1);
                 } else {
-                    //机审超过60秒的改为人工审核
+                    //机审超过300秒的改为人工审核
                     shyVideos1.setShenhe_type(CommonConst.AUDIT_TYPE_USER);
                 }
             }
+package com.cnlive.shenhe.job;
+
+import com.alibaba.fastjson.JSONObject;
+import com.cnlive.shenhe.utils.YiDunAntiFraudUtil;
+import lombok.extern.slf4j.Slf4j;
+
+import java.io.*;
+
+/**
+ * @Author: yan-zhao-wang
+ * @DateTime: 2022-06-27 10:30
+ */
+@Slf4j
+public class TextJob {
+
+
+    public static void main(String[] args) {
+        BufferedReader bufferedReader = null;
+        BufferedWriter bufferedWriter = null;
+        String type = null;
+        String desc = null;
+        try {
+            bufferedReader = new BufferedReader(new FileReader(new File("C:\\Users\\Administrator\\Desktop\\123.txt")));
+            bufferedWriter = new BufferedWriter(new BufferedWriter(new FileWriter(new File("C:\\Users\\Administrator\\Desktop\\通过数据.txt"))));
+            boolean falg = true;
+            while (falg) {
+                if (falg = (bufferedReader.readLine()) != null ? true : false) {
+                    String txt = bufferedReader.readLine();
+                    JSONObject textFilter = YiDunAntiFraudUtil.getTextFilter(txt);
+                    type = textFilter.getString("type");
+                    desc = textFilter.getString("desc");
+                    if (type.equals("PASS")) {
+                        bufferedWriter.write(txt);
+                        bufferedWriter.newLine();
+                    }
+                    log.info("type:{}" + type);
+                    log.info("desc:{}" + desc);
+                }
+            }
+
+        } catch (IOException e) {
+            e.printStackTrace();
+        } finally {
+            if (bufferedReader != null) {
+                try {
+                    bufferedReader.close();
+                } catch (IOException e) {
+                    e.printStackTrace();
+                }
+            }
+            if (bufferedWriter != null) {
+                try {
+                    bufferedWriter.close();
+                } catch (IOException e) {
+                    e.printStackTrace();
+                }
+            }
+        }
+    }
+
+}