diff --git a/src/main/java/com/nis/web/service/restful/DashboardService.java b/src/main/java/com/nis/web/service/restful/DashboardService.java index 09ba427..e0071a1 100644 --- a/src/main/java/com/nis/web/service/restful/DashboardService.java +++ b/src/main/java/com/nis/web/service/restful/DashboardService.java @@ -1,31 +1,14 @@ package com.nis.web.service.restful; -import java.util.ArrayList; -import java.util.Date; -import java.util.HashMap; -import java.util.LinkedHashMap; -import java.util.List; -import java.util.Map; - +import com.beust.jcommander.internal.Maps; +import com.nis.domain.restful.dashboard.*; +import com.nis.web.dao.dashboard.*; +import com.nis.web.service.BaseService; +import com.zdjizhi.utils.StringUtil; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; -import com.nis.domain.Page; -import com.nis.domain.restful.dashboard.NtcTotalReport; -import com.nis.domain.restful.dashboard.TrafficAppStatistic; -import com.nis.domain.restful.dashboard.TrafficHttpStatistic; -import com.nis.domain.restful.dashboard.TrafficIpActiveStatistic; -import com.nis.domain.restful.dashboard.TrafficPortActiveStatistic; -import com.nis.domain.restful.dashboard.TrafficProtocolStatistic; -import com.nis.domain.restful.dashboard.TrafficUaStatistic; -import com.nis.web.dao.dashboard.NtcTotalReportDao; -import com.nis.web.dao.dashboard.TrafficAppStatisticDao; -import com.nis.web.dao.dashboard.TrafficHttpStatisticDao; -import com.nis.web.dao.dashboard.TrafficIpActiveStatisticDao; -import com.nis.web.dao.dashboard.TrafficPortActiveStatisticDao; -import com.nis.web.dao.dashboard.TrafficProtocolStatisticDao; -import com.nis.web.dao.dashboard.TrafficUaStatisticDao; -import com.nis.web.service.BaseService; +import java.util.*; @Service public class DashboardService extends BaseService{ @@ -57,33 +40,32 @@ public class DashboardService extends BaseService{ totalReportList = ntcTotalReportDao.getTotalReportList(reportTime); } Map maxRecvtTime = ntcTotalReportDao.getMaxRecvTime(); + List newData = new ArrayList(); -// List oldData = new ArrayList(); - if(maxRecvtTime!=null&&maxRecvtTime.get("statTime")!=null) { + + if(maxRecvtTime!=null && maxRecvtTime.get("statTime")!=null) { Date recvTime = (Date) maxRecvtTime.get("statTime"); newData = ntcTotalReportDao.getNetFlowPortInfoNew(recvTime); -// oldData = ntcTotalReportDao.getNetFlowPortInfoOld(recvTime); + } //统计带宽的流入流出 单位 五分钟 的 byte - Double inoctets=0d; - Double outoctets=0d; - if(newData!=null&&newData.size()>0&&newData.get(0)!=null){ - Double newInoctets=Double.parseDouble(newData.get(0).get("inoctets").toString()) ; - Double newOutoctets=Double.parseDouble(newData.get(0).get("outoctets").toString()) ; - //结果为当前五分钟减去上个五分钟 - inoctets=newInoctets; - outoctets=newOutoctets; - if(inoctets<0||outoctets<0){ - inoctets=0d; - outoctets=0d; - } - } - if(totalReportList!=null&&totalReportList.size()>0){ - for (Map map : totalReportList) { - map.put("inoctets", inoctets); - map.put("outoctets", outoctets); + if(StringUtil.isNotEmpty(newData)){ + Double inoctets = Double.parseDouble(newData.get(0).get("inoctets").toString()) ; + Double outoctets = Double.parseDouble(newData.get(0).get("outoctets").toString()) ; + + if (StringUtil.isEmpty(totalReportList)) { + Map valueMap = Maps.newHashMap(); + valueMap.put("inoctets", inoctets); + valueMap.put("outoctets", outoctets); + totalReportList.add(valueMap); + } else { + totalReportList.get(0).put("inoctets", inoctets); + totalReportList.get(0).put("outoctets", outoctets); } + + } + return totalReportList; }