From 5002f939a7787c08774acb0ba7c89c5142aa1734 Mon Sep 17 00:00:00 2001 From: renkaige Date: Tue, 18 Dec 2018 15:29:25 +0600 Subject: [PATCH] =?UTF-8?q?1:=E4=BF=AE=E6=94=B9asn=E7=BB=9F=E8=AE=A1?= =?UTF-8?q?=E8=AE=A1=E7=AE=97=E6=95=B0=E6=8D=AE=E5=81=8F=E5=B0=8F=E7=9A=84?= =?UTF-8?q?=E9=97=AE=E9=A2=98=202:=E4=BF=AE=E6=94=B9pps=E5=8E=BB=E9=99=A4?= =?UTF-8?q?=E5=B0=8F=E6=95=B0=E7=82=B9=E5=90=8E=E9=9D=A2=E7=9A=84=E6=95=B0?= =?UTF-8?q?=E6=8D=AE=E6=97=B6,=E5=BD=93=E6=98=AF=E6=95=B4=E6=95=B0?= =?UTF-8?q?=E6=97=B6=E5=87=BA=E7=8E=B0=E5=BC=82=E5=B8=B8=E7=9A=84=E9=97=AE?= =?UTF-8?q?=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../nis/web/dao/impl/LocalLogJDBCByDruid.java | 16 ++++++++++++---- .../java/com/nis/web/service/LogDataService.java | 11 ++++++----- 2 files changed, 18 insertions(+), 9 deletions(-) diff --git a/src/main/java/com/nis/web/dao/impl/LocalLogJDBCByDruid.java b/src/main/java/com/nis/web/dao/impl/LocalLogJDBCByDruid.java index 810b360..8f28e2d 100644 --- a/src/main/java/com/nis/web/dao/impl/LocalLogJDBCByDruid.java +++ b/src/main/java/com/nis/web/dao/impl/LocalLogJDBCByDruid.java @@ -149,9 +149,12 @@ public class LocalLogJDBCByDruid { if (!allPps.equals("0")) { ntcConnRecordPercent.setPpsPercent( num.format(Double.valueOf(ntcConnRecordPercent.getPps()) / Double.valueOf(allPps))); - int idx = ntcConnRecordPercent.getPps().lastIndexOf(".");//查找小数点的位置 - String strNum = ntcConnRecordPercent.getPps().substring(0,idx);//截取从字符串开始到小数点位置的字符串，就是整数部分 - ntcConnRecordPercent.setPps(strNum); + String ppsNum =ntcConnRecordPercent.getPps(); + if(ntcConnRecordPercent.getPps().contains(".")) { + int idx =ntcConnRecordPercent.getPps().lastIndexOf(".");//查找小数点的位置 + ppsNum= ntcConnRecordPercent.getPps().substring(0,idx);//截取从字符串开始到小数点位置的字符串，就是整数部分 + } + ntcConnRecordPercent.setPps(ppsNum); } else { ntcConnRecordPercent.setPpsPercent("0%"); } @@ -191,8 +194,13 @@ public class LocalLogJDBCByDruid { NtcAsnRecord ntcAsnRecord = new NtcAsnRecord(); String bps = rs.getString("bps"); String pps = rs.getString("pps"); + String ppsNum =pps; + if(pps.contains(".")) { + int idx =pps.lastIndexOf(".");//查找小数点的位置 + ppsNum= pps.substring(0,idx);//截取从字符串开始到小数点位置的字符串，就是整数部分 + } ntcAsnRecord.setBps(subStr(bps)); - ntcAsnRecord.setPps(subStr(pps)); + ntcAsnRecord.setPps(ppsNum); ntcAsnRecord.setAsn(rs.getString("asn")); list.add(ntcAsnRecord); } diff --git a/src/main/java/com/nis/web/service/LogDataService.java b/src/main/java/com/nis/web/service/LogDataService.java index dd68b81..c91aae3 100644 --- a/src/main/java/com/nis/web/service/LogDataService.java +++ b/src/main/java/com/nis/web/service/LogDataService.java @@ -64,7 +64,7 @@ public class LogDataService { } long second = endTime - startTime; StringBuffer sql = new StringBuffer(); - sql.append("SELECT SUM(s2c_pkt_num + s2c_pkt_num)*8/"); + sql.append("SELECT SUM(s2c_pkt_num + s2c_pkt_num)/"); sql.append(second); sql.append(" AS pps , SUM(c2s_byte_num + s2c_byte_num)*8/1024/1024/1024/"); sql.append(second); @@ -98,9 +98,9 @@ public class LogDataService { long second = endTime - startTime; StringBuffer sql = new StringBuffer(); - sql.append("SELECT SUM(s2c_pkt_num + s2c_pkt_num)*8/"); + sql.append("SELECT SUM(s2c_pkt_num + s2c_pkt_num)/"); sql.append(second); - sql.append(" AS pps , SUM(c2s_byte_num + s2c_byte_num)*8/1024/1024/"); + sql.append(" AS pps , SUM(c2s_byte_num + s2c_byte_num)*8/1024/1024/1024/"); sql.append(second); sql.append(" AS bps,"); sql.append(asn); @@ -124,8 +124,9 @@ public class LogDataService { countSql.append("group by "); countSql.append(asn + ")"); Integer startNum = 0; - Integer limitCount = startNum + 20; - sql.append(" limit " + limitCount + " ) "); +// Integer limitCount = startNum + 20; +// sql.append(" limit " + limitCount + " ) "); + sql.append(" ) "); if (searchAsn != null && !searchAsn.equals("")) { sql.append(" and " + asn + "='" + searchAsn + "'"); }