编写读取文件审核关键字通过者导出文件

王言钊
1 parent ca84efa9
Showing 2 changed files with 84 additions and 0 deletions
src/main/java/com/cnlive/shenhe/job/TextJob.java
src/main/java/com/cnlive/shenhe/utils/YiDunAntiFraudUtil.java
+package com.cnlive.shenhe.job;
+
+import com.alibaba.fastjson.JSONObject;
+import com.cnlive.shenhe.utils.YiDunAntiFraudUtil;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import java.io.*;
+
+/**
+ * @Author: yan-zhao-wang
+ * @DateTime: 2022-06-27 10:30
+ */
+@Slf4j
+@Component
+public class TextJob {
+
+
+    //@Scheduled(cron = "0 0/2 * * * ? ")
+    public String TestFilter() {
+        BufferedReader bufferedReader = null;
+        BufferedWriter bufferedWriter = null;
+        String type = null;
+        String desc = null;
+        Integer action;
+        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.read()) != -1 ? true : false) {
+                    String txt = bufferedReader.readLine();
+                    String[] split = txt.split(",");
+                    JSONObject textFilter = null;
+                    for (String s : split) {
+                        textFilter = YiDunAntiFraudUtil.getTextFilter(s);
+                        type = textFilter.getString("type");
+                        desc = textFilter.getString("desc");
+                        action = textFilter.getInteger("action");
+
+                        if (action == 0) {
+                            String hint = textFilter.getString("hint");
+                            bufferedWriter.write(hint);
+                            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();
+                }
+            }
+        }
+        return "type:{}" + type + "desc:{}" + desc;
+    }
+
+}
@@ -161,6 +161,7 @@ public class YiDunAntiFraudUtil {
                     int action = resultJsonObject.getIntValue("action");
                     String taskId = resultJsonObject.getString("taskId");
                     String labelMsg = "";
+                    String hint = "";
                     if (action != 0) {
                         JSONArray labels = resultJsonObject.getJSONArray("labels");
                         labelMsg = "(";
@@ -168,6 +169,9 @@ public class YiDunAntiFraudUtil {
                             for (Object obj : labels) {
                                 JSONObject jsonObjectone = (JSONObject) obj;
                                 Integer label = jsonObjectone.getInteger("label");
+                                JSONObject details = jsonObjectone.getJSONObject("details");
+                                hint = details.getString("hint");
+
                                 String name = TextLabels.getName(label);
                                 labelMsg = labelMsg + name;
@@ -178,14 +182,20 @@ public class YiDunAntiFraudUtil {
                     if (action == 0) {
                         jsonObj.put("type", "PASS");
                         jsonObj.put("desc", "易盾文本审核通过");
+                        jsonObj.put("action", 0);
+                        jsonObj.put("hint", hint);
                     }
                     if (action == 1) {
                         jsonObj.put("type", "REJECT");
                         jsonObj.put("desc", "易盾文本审核文本嫌疑" + labelMsg + ")");
+                        jsonObj.put("hint", hint);
+                        jsonObj.put("action", 1);
                     }
                     if (action == 2) {
                         jsonObj.put("type", "REJECT");
                         jsonObj.put("desc", "易盾文本审核文本违规" + labelMsg + ")");
+                        jsonObj.put("hint", hint);
+                        jsonObj.put("action", 2);
                     }
                     jsonObj.put("taskId", taskId);
                     logger.info("审核云文本识别处理后结果:{}", jsonObj.toString());