TextJob.java
2.43 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
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;
}
}