新增app流量统计计算bps和pps的接口

src/main/java/com/nis/domain/restful/dashboard/TrafficAppBpsStatistic.java

@@ -0,0 +1,57 @@
+package com.nis.domain.restful.dashboard;
+
+import java.util.Date;
+
+import com.fasterxml.jackson.annotation.JsonIgnore;
+
+public class TrafficAppBpsStatistic extends AppTrendEntity{
+
+	private Date time;
+	private Long c2sNum;
+	private Long s2cNum;
+	private Long totalNum;
+	private String searchIspCode;// 运营商
+	private String ispNum;// device_id ,entrance_id 拼接
+
+	public Date getTime() {
+		return time;
+	}
+	public void setTime(Date time) {
+		this.time = time;
+	}
+
+
+	public Long getC2sNum() {
+		return c2sNum;
+	}
+	public void setC2sNum(Long c2sNum) {
+		this.c2sNum = c2sNum;
+	}
+	public Long getS2cNum() {
+		return s2cNum;
+	}
+	public void setS2cNum(Long s2cNum) {
+		this.s2cNum = s2cNum;
+	}
+	public Long getTotalNum() {
+		return totalNum;
+	}
+	public void setTotalNum(Long totalNum) {
+		this.totalNum = totalNum;
+	}
+	public String getSearchIspCode() {
+		return searchIspCode;
+	}
+	public void setSearchIspCode(String searchIspCode) {
+		this.searchIspCode = searchIspCode;
+	}
+	@JsonIgnore
+	public String getIspNum() {
+		return ispNum;
+	}
+	public void setIspNum(String ispNum) {
+		this.ispNum = ispNum;
+	}
+	
+	
+}

src/main/java/com/nis/domain/restful/dashboard/TrafficAppPpsStatistic.java

@@ -0,0 +1,65 @@
+package com.nis.domain.restful.dashboard;
+
+import java.util.Date;
+
+import com.fasterxml.jackson.annotation.JsonIgnore;
+
+public class TrafficAppPpsStatistic extends AppTrendEntity {
+
+	private Date time;
+	private Long c2sNum;
+	private Long s2cNum;
+	private Long totalNum;
+	private String searchIspCode;// 运营商
+	private String ispNum;// device_id ,entrance_id 拼接
+
+	public Date getTime() {
+		return time;
+	}
+
+	public void setTime(Date time) {
+		this.time = time;
+	}
+
+	public Long getC2sNum() {
+		return c2sNum;
+	}
+
+	public void setC2sNum(Long c2sNum) {
+		this.c2sNum = c2sNum;
+	}
+
+	public Long getS2cNum() {
+		return s2cNum;
+	}
+
+	public void setS2cNum(Long s2cNum) {
+		this.s2cNum = s2cNum;
+	}
+
+	public Long getTotalNum() {
+		return totalNum;
+	}
+
+	public void setTotalNum(Long totalNum) {
+		this.totalNum = totalNum;
+	}
+
+	public String getSearchIspCode() {
+		return searchIspCode;
+	}
+
+	public void setSearchIspCode(String searchIspCode) {
+		this.searchIspCode = searchIspCode;
+	}
+
+	@JsonIgnore
+	public String getIspNum() {
+		return ispNum;
+	}
+
+	public void setIspNum(String ispNum) {
+		this.ispNum = ispNum;
+	}
+
+}

src/main/java/com/nis/web/controller/restful/DashboardServiceController.java

@@ -23,11 +23,11 @@ import org.springframework.web.bind.annotation.RestController;
 import com.nis.datasource.CustomerContextHolder;
 import com.nis.domain.Page;
 import com.nis.domain.restful.NtcConnNumReport;
-import com.nis.domain.restful.NtcRadiusReport;
 import com.nis.domain.restful.dashboard.AppConnRecordStatistic;
 import com.nis.domain.restful.dashboard.AppTrendEntity;
-import com.nis.domain.restful.dashboard.SysDeviceInfo;
 import com.nis.domain.restful.dashboard.TrafficAppFocusStatistic;
+import com.nis.domain.restful.dashboard.TrafficAppBpsStatistic;
+import com.nis.domain.restful.dashboard.TrafficAppPpsStatistic;
 import com.nis.domain.restful.dashboard.TrafficAsnStatistic;
 import com.nis.restful.RestBusinessCode;
 import com.nis.restful.RestServiceException;
@@ -218,10 +218,11 @@ public class DashboardServiceController extends BaseRestController {
 	 */
 	@RequestMapping(value = "trafficBandwidthTransThree", method = RequestMethod.GET)
 	@ApiOperation(value = "带宽根据ip46,协议tcp,udp查询详情", httpMethod = "GET", notes = "对应带宽根据IPv4,6,协议tcp,udp统计数据显示")
-	public Map<String,?> trafficBandwidthTransThree(String beginDate,String endDate,String searchQuotaType,Model model,Integer searchDirection, 
-			HttpServletRequest request, HttpServletResponse response) {
+	public Map<String, ?> trafficBandwidthTransThree(String beginDate, String endDate, String searchQuotaType,
+			Model model, Integer searchDirection, HttpServletRequest request, HttpServletResponse response) {
 		long start = System.currentTimeMillis();
-		AuditLogThread auditLogThread = super.saveRequestLog(servicesRequestLogService, Constants.OPACTION_GET, request, null);
+		AuditLogThread auditLogThread = super.saveRequestLog(servicesRequestLogService, Constants.OPACTION_GET, request,
+				null);
 		Map resultMap = new HashMap();
 		try {
 			if (StringUtils.isEmpty(beginDate) && StringUtils.isEmpty(endDate)) {
@@ -231,7 +232,8 @@ public class DashboardServiceController extends BaseRestController {
 				cal.set(Calendar.HOUR_OF_DAY, cal.get(Calendar.HOUR_OF_DAY) - 1);
 				beginDate = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(cal.getTime());
 			}
-			resultMap = dashboardService.getBandwidthTransEntrance(beginDate, endDate,searchQuotaType,searchDirection);
+			resultMap = dashboardService.getBandwidthTransEntrance(beginDate, endDate, searchQuotaType,
+					searchDirection);
 
 		} catch (Exception e) {
 			auditLogThread.setExceptionInfo("带宽实时统计数据检索失败:" + e.getMessage());
@@ -247,8 +249,10 @@ public class DashboardServiceController extends BaseRestController {
 						"带宽实时统计数据检索失败:" + e.getMessage(), RestBusinessCode.service_runtime_error.getValue());
 			}
 		}
-		return serviceLogResponse(auditLogThread, System.currentTimeMillis() - start, request, "带宽实时统计数据检索成功",resultMap, 0);
+		return serviceLogResponse(auditLogThread, System.currentTimeMillis() - start, request, "带宽实时统计数据检索成功",
+				resultMap, 0);
 	}
+
 	/**
 	 * 流量统计活跃端口统计
 	 */
@@ -322,14 +326,15 @@ public class DashboardServiceController extends BaseRestController {
 	 */
 	@RequestMapping(value = "trafficProtocolList", method = RequestMethod.GET)
 	@ApiOperation(value = "协议统计占比与报表", httpMethod = "GET", notes = "对应协议统计详情占比与报表")
-	public Map<String, ?> trafficProtocolList(Integer[] protoType,String beginDate, String endDate,Integer entranceId, Model model, 
-			Integer searchDirection,HttpServletRequest request,HttpServletResponse response) {
+	public Map<String, ?> trafficProtocolList(Integer[] protoType, String beginDate, String endDate, Integer entranceId,
+			Model model, Integer searchDirection, HttpServletRequest request, HttpServletResponse response) {
 		long start = System.currentTimeMillis();
 		AuditLogThread auditLogThread = super.saveRequestLog(servicesRequestLogService, Constants.OPACTION_GET, request,
 				null);
 		List<HashMap> list = new ArrayList<HashMap>();
 		try {
-			List<Map> ipActiveList = dashboardService.getProtocolList(beginDate, endDate,protoType,entranceId,searchDirection);
+			List<Map> ipActiveList = dashboardService.getProtocolList(beginDate, endDate, protoType, entranceId,
+					searchDirection);
 			if (ipActiveList != null && ipActiveList.size() > 0) {
 				String jsonString = JsonMapper.toJsonString(ipActiveList);
 				list = (java.util.List<HashMap>) JsonMapper.fromJsonList(jsonString, HashMap.class);
@@ -517,8 +522,8 @@ public class DashboardServiceController extends BaseRestController {
 	 */
 	@RequestMapping(value = "trafficAppList", method = RequestMethod.GET)
 	@ApiOperation(value = "App统计占比与报表", httpMethod = "GET", notes = "对应App统计详情占比与报表")
-	public Map<String, ?> trafficAppList(Integer[] appType, String beginDate, String endDate, Model model,Integer entranceId,
-			HttpServletRequest request, HttpServletResponse response) {
+	public Map<String, ?> trafficAppList(Integer[] appType, String beginDate, String endDate, Model model,
+			Integer entranceId, HttpServletRequest request, HttpServletResponse response) {
 		long start = System.currentTimeMillis();
 		AuditLogThread auditLogThread = super.saveRequestLog(servicesRequestLogService, Constants.OPACTION_GET, request,
 				null);
@@ -673,8 +678,7 @@ public class DashboardServiceController extends BaseRestController {
 
 	@RequestMapping(value = "trafficWebsiteList", method = RequestMethod.GET)
 	@ApiOperation(value = "网站流量分析统计", httpMethod = "GET", notes = "对应网站http分类显示")
-	public Map<String, ?> trafficWebsiteList( Model model, HttpServletRequest request,
-			HttpServletResponse response) {
+	public Map<String, ?> trafficWebsiteList(Model model, HttpServletRequest request, HttpServletResponse response) {
 
 		long start = System.currentTimeMillis();
 		AuditLogThread auditLogThread = super.saveRequestLog(servicesRequestLogService, Constants.OPACTION_GET, request,
@@ -707,8 +711,8 @@ public class DashboardServiceController extends BaseRestController {
 
 	@RequestMapping(value = "trafficWebsiteListNoTime", method = RequestMethod.GET)
 	@ApiOperation(value = "网站流量分析详情统计", httpMethod = "GET", notes = "对应网站http分类显示")
-	public Map<String, ?> trafficWebsiteListNoTime(Integer domain[],Integer entranceId , @RequestParam String beginDate, @RequestParam String endDate,Model model, HttpServletRequest request,
-			HttpServletResponse response) {
+	public Map<String, ?> trafficWebsiteListNoTime(Integer domain[], Integer entranceId, @RequestParam String beginDate,
+			@RequestParam String endDate, Model model, HttpServletRequest request, HttpServletResponse response) {
 
 		long start = System.currentTimeMillis();
 		AuditLogThread auditLogThread = super.saveRequestLog(servicesRequestLogService, Constants.OPACTION_GET, request,
@@ -800,8 +804,8 @@ public class DashboardServiceController extends BaseRestController {
 
 	@RequestMapping(value = "trafficTopicAndDomainChart", method = RequestMethod.GET)
 	@ApiOperation(value = "HTTP网站主题分类分析统计", httpMethod = "GET", notes = "对应某个网站主题类型分类统计图")
-	public Map<String, ?> trafficTopicAndDomainChart( Model model,
-			HttpServletRequest request, HttpServletResponse response) {
+	public Map<String, ?> trafficTopicAndDomainChart(Model model, HttpServletRequest request,
+			HttpServletResponse response) {
 
 		long start = System.currentTimeMillis();
 		AuditLogThread auditLogThread = super.saveRequestLog(servicesRequestLogService, Constants.OPACTION_GET, request,
@@ -833,8 +837,8 @@ public class DashboardServiceController extends BaseRestController {
 
 	@RequestMapping(value = "trafficTopicList", method = RequestMethod.GET)
 	@ApiOperation(value = "HTTP网站主题详情", httpMethod = "GET", notes = "对应某个网站主题类型分类统计")
-	public Map<String, ?> trafficTopicList(String beginDate, String endDate, Model model,
-			HttpServletRequest request, HttpServletResponse response) {
+	public Map<String, ?> trafficTopicList(String beginDate, String endDate, Model model, HttpServletRequest request,
+			HttpServletResponse response) {
 
 		long start = System.currentTimeMillis();
 		AuditLogThread auditLogThread = super.saveRequestLog(servicesRequestLogService, Constants.OPACTION_GET, request,
@@ -878,10 +882,11 @@ public class DashboardServiceController extends BaseRestController {
 		return serviceLogResponse(auditLogThread, System.currentTimeMillis() - start, request, "HTTP网站主题分类分析数据检索成功",
 				list, 0);
 	}
+
 	@RequestMapping(value = "trafficDomainTrans", method = RequestMethod.GET)
 	@ApiOperation(value = "域名详情趋势", httpMethod = "GET", notes = "域名UV")
-	public Map<String, ?> trafficDomainTrans(String beginDate, String endDate, Model model, Integer domain,Integer entranceId,
-			HttpServletRequest request, HttpServletResponse response) {
+	public Map<String, ?> trafficDomainTrans(String beginDate, String endDate, Model model, Integer domain,
+			Integer entranceId, HttpServletRequest request, HttpServletResponse response) {
 
 		long start = System.currentTimeMillis();
 		AuditLogThread auditLogThread = super.saveRequestLog(servicesRequestLogService, Constants.OPACTION_GET, request,
@@ -913,7 +918,6 @@ public class DashboardServiceController extends BaseRestController {
 				list, 0);
 	}
 
-
 	@RequestMapping(value = "trafficPortActiveFiveMinute", method = RequestMethod.GET)
 	@ApiOperation(value = "流量端口详情趋势", httpMethod = "GET", notes = "域名UV")
 	public Map<String, ?> trafficPortAcitve(String beginDate, String endDate, Model model, Integer[] port,
@@ -956,9 +960,10 @@ public class DashboardServiceController extends BaseRestController {
 						"流量端口详情趋势数据检索失败:" + e.getMessage(), RestBusinessCode.service_runtime_error.getValue());
 			}
 		}
-		return serviceLogResponse(auditLogThread, System.currentTimeMillis() - start, request, "流量端口详情趋势数据检索成功",
-				list, 0);
+		return serviceLogResponse(auditLogThread, System.currentTimeMillis() - start, request, "流量端口详情趋势数据检索成功", list,
+				0);
 	}
+
 	@RequestMapping(value = "/trendTotalReport", method = RequestMethod.GET)
 	@ApiOperation(value = "流量各指标趋势统计", httpMethod = "GET", notes = "根据指标(drop,loop,New Link,Close Link,Pass,Live Link)统计各业务的趋势")
 	public Map<String, ?> trendTotalReport(NtcConnNumReport ntcConnNumReport, Model model, HttpServletRequest request,
@@ -972,7 +977,8 @@ public class DashboardServiceController extends BaseRestController {
 			// 验证serachBusinessType
 			if (!StringUtil.isBlank(ntcConnNumReport.getSearchBusinessType())
 					&& !StringUtil.isNumeric(ntcConnNumReport.getSearchBusinessType())) {
-				throw new RestServiceException("searchBusinessType参数格式错误", RestBusinessCode.param_formate_error.getValue());
+				throw new RestServiceException("searchBusinessType参数格式错误",
+						RestBusinessCode.param_formate_error.getValue());
 			}
 			restMap = dashboardService.trendTotalReport(ntcConnNumReport);
 		} catch (Exception e) {
@@ -990,13 +996,13 @@ public class DashboardServiceController extends BaseRestController {
 			}
 		}
 
-		return serviceLogResponse(saveLogThread, System.currentTimeMillis() - start, request, "流量各指标趋势统计成功",
-				restMap, 0);
+		return serviceLogResponse(saveLogThread, System.currentTimeMillis() - start, request, "流量各指标趋势统计成功", restMap,
+				0);
 	}
+
 	/**
 	 * @Description:
-	 * @author(zdx)
-	 * @date 2019年1月4日 下午8:57:32
+	 * @author(zdx) @date 2019年1月4日 下午8:57:32
 	 * @param model
 	 * @param entity
 	 * @param request
@@ -1005,8 +1011,8 @@ public class DashboardServiceController extends BaseRestController {
 	 */
 	@RequestMapping(value = "trafficAppTrend", method = RequestMethod.GET)
 	@ApiOperation(value = "App趋势详情查询", httpMethod = "GET", notes = "对App趋势详情提供数据查询服务")
-	public Map<String, ?> trafficAppTrend(TrafficAppFocusStatistic entity, Model model,
-			HttpServletRequest request, HttpServletResponse response) {
+	public Map<String, ?> trafficAppTrend(TrafficAppFocusStatistic entity, Model model, HttpServletRequest request,
+			HttpServletResponse response) {
 		long start = System.currentTimeMillis();
 		AuditLogThread auditLogThread = super.saveRequestLog(servicesRequestLogService, Constants.OPACTION_GET, request,
 				null);
@@ -1014,8 +1020,7 @@ public class DashboardServiceController extends BaseRestController {
 		try {
 			// 验证
 			checkAppTrendCondition(entity);
-			if (StringUtil.isEmpty(entity.getSearchStartTime())
-					&& StringUtil.isEmpty(entity.getSearchEndTime())) {
+			if (StringUtil.isEmpty(entity.getSearchStartTime()) && StringUtil.isEmpty(entity.getSearchEndTime())) {
 				Map<String, String> map = DateUtils.getLocalTime(null, null, Constants.LOG_LOCAL_TIME, "hour");
 				entity.setSearchStartTime(map.get("startTime"));
 				entity.setSearchEndTime(map.get("endTime"));
@@ -1049,8 +1054,7 @@ public class DashboardServiceController extends BaseRestController {
 
 	/**
 	 * @Description:
-	 * @author(zdx)
-	 * @date 2019年1月4日 下午8:57:12
+	 * @author(zdx) @date 2019年1月4日 下午8:57:12
 	 * @param beginDate
 	 * @param endDate
 	 * @param model
@@ -1070,8 +1074,7 @@ public class DashboardServiceController extends BaseRestController {
 		try {
 			// 验证
 			checkAppTrendCondition(entity);
-			if (StringUtil.isEmpty(entity.getSearchStartTime())
-					&& StringUtil.isEmpty(entity.getSearchEndTime())) {
+			if (StringUtil.isEmpty(entity.getSearchStartTime()) && StringUtil.isEmpty(entity.getSearchEndTime())) {
 				Map<String, String> map = DateUtils.getLocalTime(null, null, Constants.LOG_LOCAL_TIME, "hour");
 				entity.setSearchStartTime(map.get("startTime"));
 				entity.setSearchEndTime(map.get("endTime"));
@@ -1082,20 +1085,18 @@ public class DashboardServiceController extends BaseRestController {
 				ispNum = dashboardService.getIspNum(entity.getSearchIspCode());
 				entity.setIspNum(ispNum);
 			}
-//			List<SysDeviceInfo> sysDeviceInfo =dashboardService.getIspListByIspNum(ispNum);
+			// List<SysDeviceInfo> sysDeviceInfo
+			// =dashboardService.getIspListByIspNum(ispNum);
 			CustomerContextHolder.setCustomerType(CustomerContextHolder.DATA_SOURCE_B);
 			list = dashboardService.appConnRecordTop100(entity);
 			// 设置运营商编码
-			/*if(list!=null&&list.size()>0&&sysDeviceInfo!=null&&sysDeviceInfo.size()>0){
-				for (AppConnRecordStatistic app : list) {
-					for (SysDeviceInfo device : sysDeviceInfo) {
-						if((app.getIspNum().trim()).equals(device.getIspNum().trim())){
-							app.setIspName(device.getIspName());
-							break;
-						}
-					}
-				}
-			}*/
+			/*
+			 * if(list!=null&&list.size()>0&&sysDeviceInfo!=null&&sysDeviceInfo.size()>0){
+			 * for (AppConnRecordStatistic app : list) { for (SysDeviceInfo device :
+			 * sysDeviceInfo) {
+			 * if((app.getIspNum().trim()).equals(device.getIspNum().trim())){
+			 * app.setIspName(device.getIspName()); break; } } } }
+			 */
 			CustomerContextHolder.clearCustomerType();
 
 		} catch (Exception e) {
@@ -1112,22 +1113,14 @@ public class DashboardServiceController extends BaseRestController {
 						"App通联关系Top100数据检索失败:" + e.getMessage(), RestBusinessCode.service_runtime_error.getValue());
 			}
 		}
-		return serviceLogResponse(auditLogThread, System.currentTimeMillis() - start, request, "App通联关系Top100数据检索成功", list,
-				0);
+		return serviceLogResponse(auditLogThread, System.currentTimeMillis() - start, request, "App通联关系Top100数据检索成功",
+				list, 0);
 	}
 
-	
-	
-	
-	
-	
-	
-	
-
 	@RequestMapping(value = "/ntcAsnRecord", method = RequestMethod.GET)
 	@ApiOperation(value = "ASN通联关系(源,目的)查询", httpMethod = "GET", notes = "对日志功能“ASN通联关系(源,目的)查询”提供数据基础查询服务")
-	public Map<String, ?> ntcAsnRecord(Page page, TrafficAsnStatistic ntcAsnRecord, Model model, HttpServletRequest request,
-			HttpServletResponse response) {
+	public Map<String, ?> ntcAsnRecord(Page page, TrafficAsnStatistic ntcAsnRecord, Model model,
+			HttpServletRequest request, HttpServletResponse response) {
 		long start = System.currentTimeMillis();
 		AuditLogThread auditLogThread = super.saveRequestLog(servicesRequestLogService, Constants.OPACTION_GET, request,
 				null);
@@ -1201,18 +1194,6 @@ public class DashboardServiceController extends BaseRestController {
 				page, 0);
 	}
 
-	
-	
-	
-	
-	
-	
-	
-	
-	
-	
-	
-	
 	/**
 	 */
 	public void checkAppTrendCondition(AppTrendEntity entity) {
@@ -1224,11 +1205,9 @@ public class DashboardServiceController extends BaseRestController {
 				timeCount++;
 			}
 		} catch (ParseException e) {
-			throw new RestServiceException("searchStartTime参数格式错误",
-					RestBusinessCode.param_formate_error.getValue());
+			throw new RestServiceException("searchStartTime参数格式错误", RestBusinessCode.param_formate_error.getValue());
 		} catch (Exception e) {
-			throw new RestServiceException("searchStartTime参数错误",
-					RestBusinessCode.param_formate_error.getValue());
+			throw new RestServiceException("searchStartTime参数错误", RestBusinessCode.param_formate_error.getValue());
 		}
 
 		try {
@@ -1237,8 +1216,7 @@ public class DashboardServiceController extends BaseRestController {
 				timeCount++;
 			}
 		} catch (ParseException e) {
-			throw new RestServiceException("searchEndTime参数格式错误",
-					RestBusinessCode.param_formate_error.getValue());
+			throw new RestServiceException("searchEndTime参数格式错误", RestBusinessCode.param_formate_error.getValue());
 		} catch (Exception e) {
 			throw new RestServiceException("searchEndTime参数错误", RestBusinessCode.param_formate_error.getValue());
 		}
@@ -1255,6 +1233,7 @@ public class DashboardServiceController extends BaseRestController {
 		logger.info("用户行为日志统计参数校验结束----" + System.currentTimeMillis());
 
 	}
+
 	public void checkNumericCondition(String condition, String condName) {
 		if (!StringUtil.isEmpty(condition)) {
 			Boolean flag = false;
@@ -1274,4 +1253,107 @@ public class DashboardServiceController extends BaseRestController {
 			}
 		}
 	}
+
+	/**
+	 * @Description:获取指定app流量bps值
+	 * @param model
+	 * @param entity
+	 * @param request
+	 * @param response
+	 * @return
+	 */
+	@RequestMapping(value = "trafficAppBpsTrend", method = RequestMethod.GET)
+	@ApiOperation(value = "App-bps趋势详情查询", httpMethod = "GET", notes = "对App-bps趋势详情提供数据查询服务")
+	public Map<String, ?> trafficAppBpsTrend(TrafficAppBpsStatistic entity, Model model, HttpServletRequest request,
+			HttpServletResponse response) {
+		long start = System.currentTimeMillis();
+		AuditLogThread auditLogThread = super.saveRequestLog(servicesRequestLogService, Constants.OPACTION_GET, request,
+				null);
+		Map resultMap = new HashMap();
+		try {
+			// 验证
+			checkAppTrendCondition(entity);
+			if (StringUtil.isEmpty(entity.getSearchStartTime()) && StringUtil.isEmpty(entity.getSearchEndTime())) {
+				Map<String, String> map = DateUtils.getLocalTime(null, null, Constants.LOG_LOCAL_TIME, "hour");
+				entity.setSearchStartTime(map.get("startTime"));
+				entity.setSearchEndTime(map.get("endTime"));
+			}
+			if (StringUtils.isNotBlank(entity.getSearchIspCode())) {
+				String ispNum = dashboardService.getIspNum(entity.getSearchIspCode());
+				entity.setIspNum(ispNum);
+			}
+			// 将数据源切换到本地clickhouse
+			CustomerContextHolder.setCustomerType(CustomerContextHolder.DATA_SOURCE_B);
+			resultMap = dashboardService.getAppBpsTrend(entity);
+			CustomerContextHolder.clearCustomerType();
+		} catch (Exception e) {
+			auditLogThread.setExceptionInfo("App-bps趋势详情数据检索失败:" + e.getMessage());
+			logger.error("App-bps趋势详情数据检索失败:" + ExceptionUtil.getExceptionMsg(e));
+			if (e instanceof RestServiceException) {
+				throw new RestServiceException(auditLogThread, System.currentTimeMillis() - start,
+						"App-bps趋势详情数据检索失败:" + e.getMessage(), ((RestServiceException) e).getErrorCode());
+			} else if (e instanceof ServiceRuntimeException) {
+				throw new ServiceRuntimeException(auditLogThread, System.currentTimeMillis() - start,
+						"App-bps趋势详情数据检索失败:" + e.getMessage(), ((ServiceRuntimeException) e).getErrorCode());
+			} else {
+				throw new ServiceRuntimeException(auditLogThread, System.currentTimeMillis() - start,
+						"App-bps趋势详情数据检索失败:" + e.getMessage(), RestBusinessCode.service_runtime_error.getValue());
+			}
+		}
+
+		return serviceLogResponse(auditLogThread, System.currentTimeMillis() - start, request, "App-bps趋势详情数据检索成功",
+				resultMap, 0);
+	}
+
+	/**
+	 * 获取指定app流量pps值
+	 * @param entity
+	 * @param model
+	 * @param request
+	 * @param response
+	 * @return
+	 */
+	@RequestMapping(value = "trafficAppPpsTrend", method = RequestMethod.GET)
+	@ApiOperation(value = "App-pps趋势详情查询", httpMethod = "GET", notes = "对App-pps趋势详情提供数据查询服务")
+	public Map<String, ?> trafficAppPpsTrend(TrafficAppPpsStatistic entity, Model model, HttpServletRequest request,
+			HttpServletResponse response) {
+		long start = System.currentTimeMillis();
+		AuditLogThread auditLogThread = super.saveRequestLog(servicesRequestLogService, Constants.OPACTION_GET, request,
+				null);
+		Map resultMap = new HashMap();
+		try {
+			// 验证
+			checkAppTrendCondition(entity);
+			if (StringUtil.isEmpty(entity.getSearchStartTime()) && StringUtil.isEmpty(entity.getSearchEndTime())) {
+				Map<String, String> map = DateUtils.getLocalTime(null, null, Constants.LOG_LOCAL_TIME, "hour");
+				entity.setSearchStartTime(map.get("startTime"));
+				entity.setSearchEndTime(map.get("endTime"));
+			}
+			if (StringUtils.isNotBlank(entity.getSearchIspCode())) {
+				String ispNum = dashboardService.getIspNum(entity.getSearchIspCode());
+				entity.setIspNum(ispNum);
+			}
+			// 将数据源切换到本地clickhouse
+			CustomerContextHolder.setCustomerType(CustomerContextHolder.DATA_SOURCE_B);
+			resultMap = dashboardService.getAppPpsTrend(entity);
+			CustomerContextHolder.clearCustomerType();
+		} catch (Exception e) {
+			auditLogThread.setExceptionInfo("App-Gbps趋势详情数据检索失败:" + e.getMessage());
+			logger.error("App-pps趋势详情数据检索失败:" + ExceptionUtil.getExceptionMsg(e));
+			if (e instanceof RestServiceException) {
+				throw new RestServiceException(auditLogThread, System.currentTimeMillis() - start,
+						"App-pps趋势详情数据检索失败:" + e.getMessage(), ((RestServiceException) e).getErrorCode());
+			} else if (e instanceof ServiceRuntimeException) {
+				throw new ServiceRuntimeException(auditLogThread, System.currentTimeMillis() - start,
+						"App-pps趋势详情数据检索失败:" + e.getMessage(), ((ServiceRuntimeException) e).getErrorCode());
+			} else {
+				throw new ServiceRuntimeException(auditLogThread, System.currentTimeMillis() - start,
+						"App-pps趋势详情数据检索失败:" + e.getMessage(), RestBusinessCode.service_runtime_error.getValue());
+			}
+		}
+
+		return serviceLogResponse(auditLogThread, System.currentTimeMillis() - start, request, "App-pps趋势详情数据检索成功",
+				resultMap, 0);
+	}
+
 }

src/main/java/com/nis/web/dao/dashboard/TrafficAppStatisticDao.java

@@ -5,8 +5,11 @@ import java.util.List;
 import java.util.Map;
 
 import org.apache.ibatis.annotations.Param;
+
 import com.nis.domain.restful.dashboard.AppConnRecordStatistic;
 import com.nis.domain.restful.dashboard.TrafficAppFocusStatistic;
+import com.nis.domain.restful.dashboard.TrafficAppBpsStatistic;
+import com.nis.domain.restful.dashboard.TrafficAppPpsStatistic;
 import com.nis.domain.restful.dashboard.TrafficAppStatistic;
 import com.nis.web.dao.MyBatisDao;
 @MyBatisDao
@@ -16,6 +19,8 @@ public interface TrafficAppStatisticDao {
 	List<Map> appChart(@Param("statTime")Date statTime);
 	List<Map> getAppList(@Param("beginTime")String beginTime,@Param("endTime")String endTime,@Param("appType")Integer[] appType,@Param("entranceId")Integer entranceId);
 	List<TrafficAppFocusStatistic> getAppTrend(TrafficAppFocusStatistic entity);
+	List<TrafficAppBpsStatistic> getAppBpsTrend(TrafficAppBpsStatistic entity);
+	List<TrafficAppPpsStatistic> getAppPpsTrend(TrafficAppPpsStatistic entity);
 	List<AppConnRecordStatistic> appConnRecordTop100(AppConnRecordStatistic entity);
 	List<AppConnRecordStatistic> appConnRecordTotal(AppConnRecordStatistic entity);
 }

src/main/java/com/nis/web/dao/dashboard/TrafficAppStatisticDao.xml

@@ -59,6 +59,32 @@
 		group by stat_time
 		 order by stat_time
 	</select>
+  <select id="getAppBpsTrend" parameterType="com.nis.domain.restful.dashboard.TrafficAppBpsStatistic" resultType="com.nis.domain.restful.dashboard.TrafficAppBpsStatistic">
+		select stat_time time, sum(c2s_byte_len) c2sNum,sum(s2c_byte_len) s2cNum,sum(s2c_byte_len+c2s_byte_len) totalNum from traffic_app_focus_statistic t where
+		<![CDATA[ stat_time>= toDateTime(#{searchStartTime}) and stat_time< toDateTime(#{searchEndTime})
+			and app_id=toInt64(#{searchAppId}) ]]>
+		<if test="searchEntranceId !=null and searchEntranceId != ''">
+			<![CDATA[and entrance_id=toInt64(#{searchEntranceId}) ]]>
+		</if>
+		<if test="ispNum !=null and ispNum != ''">
+			<![CDATA[and concat(toString(entrance_id),toString(device_id)) in (${ispNum})]]>
+		</if>
+		group by stat_time
+		 order by stat_time
+	</select>
+  <select id="getAppPpsTrend" parameterType="com.nis.domain.restful.dashboard.TrafficAppPpsStatistic" resultType="com.nis.domain.restful.dashboard.TrafficAppPpsStatistic">
+		select stat_time time, sum(c2s_pkt_num) c2sNum,sum(s2c_pkt_num) s2cNum,sum(s2c_pkt_num+c2s_pkt_num) totalNum from traffic_app_focus_statistic t where
+		<![CDATA[ stat_time>= toDateTime(#{searchStartTime}) and stat_time< toDateTime(#{searchEndTime})
+			and app_id=toInt64(#{searchAppId}) ]]>
+		<if test="searchEntranceId !=null and searchEntranceId != ''">
+			<![CDATA[and entrance_id=toInt64(#{searchEntranceId}) ]]>
+		</if>
+		<if test="ispNum !=null and ispNum != ''">
+			<![CDATA[and concat(toString(entrance_id),toString(device_id)) in (${ispNum})]]>
+		</if>
+		group by stat_time
+		 order by stat_time
+	</select>
 	<!-- App 活跃IP Top100 -->
 	<select id="appConnRecordTop100" parameterType="com.nis.domain.restful.dashboard.AppConnRecordStatistic" resultType="com.nis.domain.restful.dashboard.AppConnRecordStatistic">
 		select s_ip ipAddr, sum(c2s_byte_num + s2c_byte_num) byteNum, sum(c2s_pkt_num + s2c_pkt_num) pktNum, count(s_ip) logNum

src/main/java/com/nis/web/service/restful/DashboardService.java

@@ -16,7 +16,6 @@ import java.util.List;
 import java.util.Map;
 import java.util.Map.Entry;
 import java.util.Set;
-import java.util.TreeMap;
 
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -29,6 +28,8 @@ import com.nis.domain.restful.dashboard.AppConnRecordStatistic;
 import com.nis.domain.restful.dashboard.NtcTotalReport;
 import com.nis.domain.restful.dashboard.SysDeviceInfo;
 import com.nis.domain.restful.dashboard.TrafficAppFocusStatistic;
+import com.nis.domain.restful.dashboard.TrafficAppBpsStatistic;
+import com.nis.domain.restful.dashboard.TrafficAppPpsStatistic;
 import com.nis.domain.restful.dashboard.TrafficAppStatistic;
 import com.nis.domain.restful.dashboard.TrafficAsnStatistic;
 import com.nis.domain.restful.dashboard.TrafficHttpFocusStatistic;
@@ -1754,6 +1755,162 @@ public class DashboardService extends BaseService {
 			resultMap.put("dipSum", dipTotal);
 		}
 		return resultMap;
+	}
+	public Map getAppBpsTrend(TrafficAppBpsStatistic entity) {
+		List<TrafficAppBpsStatistic> list = new ArrayList<TrafficAppBpsStatistic>();
+		list = trafficAppStatisticDao.getAppBpsTrend(entity);
+		Map resultMap = new  HashMap();
+		if(!StringUtil.isEmpty(list)){
+			Date beginDate = DateUtils.parseDate(entity.getSearchStartTime());
+			Date endDate = DateUtils.parseDate(entity.getSearchEndTime());
+			List<Date> dateRangeList = new ArrayList<Date>();
+			Calendar calendar = Calendar.getInstance();
+			calendar.setTime(beginDate);
+			SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+			while (calendar.getTime().compareTo(endDate) < 0) {
+				dateRangeList.add(calendar.getTime());
+				calendar.add(Calendar.MINUTE, 1);
+			}
+			int index = 0;
+			List resultC2sList = new ArrayList();
+			List resultS2cList = new ArrayList();
+			List resultTotalList = new ArrayList();
+//			Long c2sTotal = 0L;
+//			Long s2cTotal = 0L;
+//			Long c2sS2cTotal = 0L;
+			for (int i = 0; i < dateRangeList.size(); i++) {
+				// 存放一个时间点中总数
+				List c2sList = new ArrayList();
+				List s2cList = new ArrayList();
+				List totalList = new ArrayList();
+				Date date = dateRangeList.get(i);
+				Long c2sNum = 0L;
+				Long s2cNum = 0L;
+				Long totalNum=0L;
+				for (int j = index; j < list.size(); j++) {
+					TrafficAppBpsStatistic info = list.get(j);
+					if (info.getTime() != null) {
+						if (info.getTime().compareTo(date) >= 0 && (i + 1 < dateRangeList.size()?info.getTime().compareTo(dateRangeList.get(i + 1)) < 0:true)) {
+							c2sNum = c2sNum + info.getC2sNum();
+							s2cNum = s2cNum + info.getS2cNum();
+							totalNum=totalNum+info.getTotalNum();
+						} else {
+							index = j;
+							break;
+						}
+					}
+				}
+				
+				//最后一个时间点
+				if(i+1==dateRangeList.size()&&s2cNum.compareTo(0L)==0&&c2sNum.compareTo(0L)==0){
+					break;
+				}
+				c2sList.add(date.getTime());
+				c2sList.add(c2sNum*8/1024/1024/1024/60);
+				resultC2sList.add(c2sList);
+				s2cList.add(date.getTime());
+				s2cList.add(s2cNum*8/1024/1024/1024/60);
+				resultS2cList.add(s2cList);
+				
+				totalList.add(date.getTime());
+				totalList.add(totalNum*8/1024/1024/1024/60);
+				resultTotalList.add(totalList);
+				
+//				c2sTotal+=c2sNum;
+//				s2cTotal+=s2cNum;
+//				c2sS2cTotal+=totalNum;
+			}
+			resultMap.put("c2sResult", resultC2sList);
+			resultMap.put("s2cResult", resultS2cList);
+			resultMap.put("totalResult", resultTotalList);
+//			resultMap.put("c2sSum", c2sTotal*8/1024/1024/1024/60);
+//			resultMap.put("s2cSum", s2cTotal*8/1024/1024/1024/60);
+//			resultMap.put("totalSum", c2sS2cTotal*8/1024/1024/1024/60);
+		}
+		return resultMap;
+	
+		
+	}
+	public Map getAppPpsTrend(TrafficAppPpsStatistic entity) {
+		List<TrafficAppPpsStatistic> list = new ArrayList<TrafficAppPpsStatistic>();
+		list = trafficAppStatisticDao.getAppPpsTrend(entity);
+		Map resultMap = new  HashMap();
+		if(!StringUtil.isEmpty(list)){
+			Date beginDate = DateUtils.parseDate(entity.getSearchStartTime());
+			Date endDate = DateUtils.parseDate(entity.getSearchEndTime());
+			List<Date> dateRangeList = new ArrayList<Date>();
+			Calendar calendar = Calendar.getInstance();
+			calendar.setTime(beginDate);
+			SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+			while (calendar.getTime().compareTo(endDate) < 0) {
+				dateRangeList.add(calendar.getTime());
+				calendar.add(Calendar.MINUTE, 1);
+			}
+			int index = 0;
+			List resultC2sList = new ArrayList();
+			List resultS2cList = new ArrayList();
+			List resultTotalList = new ArrayList();
+//			Long c2sTotal = 0L;
+//			Long s2cTotal = 0L;
+//			Long c2sS2cTotal = 0L;
+			for (int i = 0; i < dateRangeList.size(); i++) {
+				// 存放一个时间点中总数
+				List c2sList = new ArrayList();
+				List s2cList = new ArrayList();
+				List totalList = new ArrayList();
+				Date date = dateRangeList.get(i);
+				Long c2sNum = 0L;
+				Long s2cNum = 0L;
+				Long totalNum=0L;
+				if(i==33) {
+					System.out.println();
+				}
+				for (int j = index; j < list.size(); j++) {
+					TrafficAppPpsStatistic info = list.get(j);
+					if (info.getTime() != null) {
+						if (info.getTime().compareTo(date) >= 0 && (i + 1 < dateRangeList.size()?info.getTime().compareTo(dateRangeList.get(i + 1)) < 0:true)) {
+							c2sNum = c2sNum + info.getC2sNum();
+							s2cNum = s2cNum + info.getS2cNum();
+							totalNum=totalNum+info.getTotalNum();
+						} else {
+							index = j;
+							break;
+						}
+					}
+				}
+				
+				//最后一个时间点
+				if(i+1==dateRangeList.size()&&s2cNum.compareTo(0L)==0&&c2sNum.compareTo(0L)==0){
+					break;
+				}
+				c2sList.add(date.getTime());
+				c2sList.add(c2sNum/60);
+				resultC2sList.add(c2sList);
+				s2cList.add(date.getTime());
+				s2cList.add(s2cNum/60);
+				resultS2cList.add(s2cList);
+				
+				
+				totalList.add(date.getTime());
+				totalList.add(totalNum/60);
+				resultTotalList.add(totalList);
+				
+//				c2sTotal+=c2sNum;
+//				s2cTotal+=s2cNum;
+//				c2sS2cTotal+=totalNum;
+			}
+			resultMap.put("c2sResult", resultC2sList);
+			resultMap.put("s2cResult", resultS2cList);
+			resultMap.put("totalResult", resultTotalList);
+//			resultMap.put("c2sSum", c2sTotal);
+//			resultMap.put("s2cSum", s2cTotal);
+//			resultMap.put("totalSum", c2sS2cTotal);
+		}
+		return resultMap;
+		
+		
+	
+		
 	}
 	
 	public List<AppConnRecordStatistic> appConnRecordTop100(AppConnRecordStatistic entity) {