gfwleak/k18-ntcs-web-argus-service
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

为asn单向流统计添加运营商查询条件

Browse Source
This commit is contained in:
renkaige
2019-01-08 19:11:50 +06:00
parent 39a86d948b
commit 8c88334ba4
1 changed files with 12 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
src/main/java/com/nis/web/service/LogDataService.java
View File

@@ -63,7 +63,7 @@ public class LogDataService {
}
long second = endTime - startTime;
StringBuffer sql = new StringBuffer();
sql.append("SELECT SUM(s2c_pkt_num + s2c_pkt_num)/");
sql.append("SELECT SUM(s2c_pkt_num + c2s_pkt_num)/");
sql.append(second);
sql.append(" AS pps , SUM(c2s_byte_num + s2c_byte_num)*8/1024/1024/1024/");
sql.append(second);
@@ -74,8 +74,17 @@ public class LogDataService {
sql.append(endTime);
StringBuffer totalSql = new StringBuffer();
totalSql.append(sql);
totalSql.append(" and stream_dir in(1,2,3)) and stream_dir in(1,2,3)");
sql.append(" and stream_dir in(1,2) ) and stream_dir in(1,2)");
if (ntcConnRecordPercent.getSearchEntranceId() != null
&& !ntcConnRecordPercent.getSearchEntranceId().trim().equals("")) {
totalSql.append(" and stream_dir in(1,2,3) and entrance_id =" + ntcConnRecordPercent.getSearchEntranceId()
+ " ) and stream_dir in(1,2,3) and entrance_id =" + ntcConnRecordPercent.getSearchEntranceId());
sql.append(" and stream_dir in(1,2) and entrance_id =" + ntcConnRecordPercent.getSearchEntranceId()
+ " ) and stream_dir in(1,2) and entrance_id =" + ntcConnRecordPercent.getSearchEntranceId());
} else {
totalSql.append(" and stream_dir in(1,2,3)) and stream_dir in(1,2,3)");
sql.append(" and stream_dir in(1,2) ) and stream_dir in(1,2) ");
}
localLogJDBCByDruid.getNtcConnRecordPercentData(ntcConnRecordPercent, sql.toString(), false);
localLogJDBCByDruid.getNtcConnRecordPercentData(ntcConnRecordPercent, totalSql.toString(), true);
return ntcConnRecordPercent;