diff --git a/src/main/java/com/nis/domain/restful/NtcAsnRecord.java b/src/main/java/com/nis/domain/restful/NtcAsnRecord.java index 3cb29d3..7f8b1ed 100644 --- a/src/main/java/com/nis/domain/restful/NtcAsnRecord.java +++ b/src/main/java/com/nis/domain/restful/NtcAsnRecord.java @@ -21,6 +21,9 @@ public class NtcAsnRecord implements Serializable { private String bps; private String pps; private String asn; + + + private String searchAsn; private String searchFoundStartTime;// 开始发现时间 private String searchFoundEndTime;// 结束发现时间 @@ -50,6 +53,15 @@ public class NtcAsnRecord implements Serializable { this.asn = asn; } + @JsonIgnore + public String getSearchAsn() { + return searchAsn; + } + + public void setSearchAsn(String searchAsn) { + this.searchAsn = searchAsn; + } + @JsonIgnore public String getSearchAsnType() { return searchAsnType; diff --git a/src/main/java/com/nis/web/dao/NtcReportDao.xml b/src/main/java/com/nis/web/dao/NtcReportDao.xml index f5fe55a..4839b66 100644 --- a/src/main/java/com/nis/web/dao/NtcReportDao.xml +++ b/src/main/java/com/nis/web/dao/NtcReportDao.xml @@ -75,7 +75,8 @@ type="com.nis.domain.restful.NtcURLIpReport"> - + - + @@ -755,12 +757,12 @@ ${page.fields} - url, ipCount,connCount + url, ipCount,connCount FROM (SELECT url, - count(distinct ip_addr) ipCount, - sum(sum) connCount + count(distinct ip_addr) ipCount, + sum(sum) connCount FROM ntc_reject_url_statistic @@ -776,8 +778,8 @@ AND url like concat(concat('%',#{searchUrl}),'%') - GROUP BY url - ) ntc_reject_url_statistic ORDER BY ipcount desc,connCount desc + GROUP BY url + ) ntc_reject_url_statistic ORDER BY ipcount desc,connCount desc @@ -850,7 +852,8 @@ \ No newline at end of file diff --git a/src/main/java/com/nis/web/service/LogDataService.java b/src/main/java/com/nis/web/service/LogDataService.java index 635b9d7..dd68b81 100644 --- a/src/main/java/com/nis/web/service/LogDataService.java +++ b/src/main/java/com/nis/web/service/LogDataService.java @@ -89,9 +89,8 @@ public class LogDataService { throw new RestServiceException("searchFoundStartTime() can not exceed searchFoundEndTime", RestBusinessCode.param_formate_error.getValue()); } - - - + + String searchAsn = ntcAsnRecord.getSearchAsn(); String asn = "s_asn "; if (ntcAsnRecord.getSearchAsnType().trim().equals("1")) { asn = "d_asn "; @@ -110,16 +109,27 @@ public class LogDataService { sql.append(startTime); sql.append(" and found_time< "); sql.append(endTime); + + if (searchAsn != null && !searchAsn.equals("")) { + sql.append(" and " + asn + "='" + searchAsn + "'"); + } + StringBuffer countSql = new StringBuffer(); countSql.append("select count(1) from ("); countSql.append(sql); - countSql.append(" ) group by "); - countSql.append(asn+")"); - Integer startNum = (page.getPageNo() - 1) * page.getPageSize(); - Integer limitCount = startNum + page.getPageSize(); - - sql.append(" limit " + limitCount + " ) group by "+asn+" order by bps desc,pps desc limit " + startNum + "," + page.getPageSize()); - + countSql.append(" ) "); + if (searchAsn != null && !searchAsn.equals("")) { + countSql.append(" and " + asn + "='" + searchAsn + "'"); + } + countSql.append("group by "); + countSql.append(asn + ")"); + Integer startNum = 0; + Integer limitCount = startNum + 20; + sql.append(" limit " + limitCount + " ) "); + if (searchAsn != null && !searchAsn.equals("")) { + sql.append(" and " + asn + "='" + searchAsn + "'"); + } + sql.append("group by " + asn + " order by bps desc,pps desc limit " + startNum + "," + 20); localLogJDBCByDruid.getCount(page, countSql.toString()); page.setList(localLogJDBCByDruid.getNtcAsnRecordData(sql.toString()));