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
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
|
package cn.ac.iie.common;
import org.apache.log4j.Logger;
import java.text.SimpleDateFormat;
import java.util.Map;
public class DataCenterLoad {
private static final String url = HttpManager.getInfoLoadInstance().getAddress();
private static Logger logger = Logger.getLogger(DataCenterLoad.class);
public DataCenterLoad() {
}
private String generateTimeWithInterval() {
Long stamp = System.currentTimeMillis() + 300000L;
Long stamp5 = stamp / 300000 * 300000;
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
return df.format(stamp5);
}
public void dfPzFlowBatchStorage(Map<String, Long> pzMap) {
//String sql = " insert into DF_PZ_REPORT(STAT_ID, ACTIVE_SYS, CFG_ID, SERVICE, SUM, REPORT_TIME) " +
// " VALUES(SEQ_DF_PZ_REPORT.NEXTVAL, ?, ?, ?, ?, ?)";
StringBuffer sb = new StringBuffer();
String time5 = generateTimeWithInterval();
int nums = 0;
for (String key : pzMap.keySet()) {
try {
String[] options = key.split(RealtimeCountConfig.BETWEEN_BOLTS_SPLITTER);
if (options[0] != null && options[0] != "" && options[1] != null && options[1] != "" && options[2] != null && options[2] != "" && options[3] != null && options[3] != "" && options[4] != null && options[4] != "" && options[5] != null && options[5] != "") {
String aItem = options[0] + "," + options[1] + "," + options[2] + "," + options[3] + "," + options[4] + "," + options[5] + "," + pzMap.get(key) + "," + time5;
sb.append(aItem + "\n");
nums++;
if (nums >= RealtimeCountConfig.BATCH_INSERT_NUM) {
String data = sb.substring(0, sb.length() - 1);
//输出的topic
logger.info("start to post data to dc---------> " + data);
System.out.println("start to post data to dc---------> " + data);
HttpManager.getInfoLoadInstance().postToDataCenter(url, "DF_PZ_FLOW_REPORT", data);//原本的方法
sb.setLength(0);
nums = 0;
}
}
} catch (Exception e) {
e.printStackTrace();
}
}
try {
if (nums != 0) {
String data = sb.substring(0, sb.length() - 1);
HttpManager.getInfoLoadInstance().postToDataCenter(url, "DF_PZ_FLOW_REPORT", data);
sb.setLength(0);
nums = 0;
}
} catch (Exception e) {
e.printStackTrace();
}
}
public void dfPzBatchStorage(Map<String, Long> pzMap) {
//String sql = " insert into DF_PZ_REPORT(STAT_ID, ACTIVE_SYS, CFG_ID, SERVICE, SUM, REPORT_TIME) " +
// " VALUES(SEQ_DF_PZ_REPORT.NEXTVAL, ?, ?, ?, ?, ?)";
StringBuffer sb = new StringBuffer();
String time5 = generateTimeWithInterval();
int nums = 0;
for (String key : pzMap.keySet()) {
try {
String[] options = key.split(RealtimeCountConfig.BETWEEN_BOLTS_SPLITTER);
String aItem = options[2] + "\t" + options[1] + "\t" + options[3] + "\t" + pzMap.get(key) + "\t" + time5;
sb.append(aItem + "\n");
nums++;
if (nums >= RealtimeCountConfig.BATCH_INSERT_NUM) {
String data = sb.substring(0, sb.length() - 1);
HttpManager.getInfoLoadInstance().postToDataCenter(url, "t_xa_df_pz_report_dt", data);
sb.setLength(0);
nums = 0;
}
} catch (Exception e) {
e.printStackTrace();
}
}
try {
if (nums != 0) {
String data = sb.substring(0, sb.length() - 1);
HttpManager.getInfoLoadInstance().postToDataCenter(url, "t_xa_df_pz_report_dt", data);
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
|
