k18-ntcs-web-argus-service/src/main/java/com/nis/web/controller/restful/DashboardServiceController.java

package com.nis.web.controller.restful;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

import com.nis.restful.RestBusinessCode;
import com.nis.restful.ServiceRuntimeException;
import com.nis.util.Constants;
import com.nis.util.ExceptionUtil;
import com.nis.util.JsonMapper;
import com.nis.web.controller.BaseRestController;
import com.nis.web.service.AuditLogThread;
import com.nis.web.service.ServicesRequestLogService;
import com.nis.web.service.restful.DashboardService;
import com.wordnik.swagger.annotations.Api;
import com.wordnik.swagger.annotations.ApiOperation;

@RestController
@RequestMapping(value = "${servicePath}/log/v1")
@Api(value = "DashboardServiceController", description = "统计分析图表基本服务接口")
public class DashboardServiceController extends BaseRestController {
	
	@Autowired
	protected ServicesRequestLogService servicesRequestLogService;
	@Autowired
	public DashboardService dashboardService;
	
	/**
	 * 流量统计info滚动条数据显示 封堵监测回流丢弃
	 */
	@RequestMapping(value = "ntcTotalReport", method = RequestMethod.GET)
	@ApiOperation(value = "业务总量汇聚", httpMethod = "GET", notes = "对应流量统计info滚动条数据显示")
	public Map<String,?> ntcTotalReport(Model model, HttpServletRequest request, HttpServletResponse response) {

		long start = System.currentTimeMillis();
		AuditLogThread auditLogThread = super.saveRequestLog(servicesRequestLogService, Constants.OPACTION_GET, request, null);
		List<Map> list = new ArrayList<Map>();
		try {
			List<Map> resultList = dashboardService.getTotalReportList();
				if (resultList!=null&&resultList.size() > 0) {
					list = resultList;
			}
		} catch (Exception e) {
			e.printStackTrace();
			auditLogThread.setExceptionInfo(e.getMessage() + " " + e.getCause());
			logger.error("业务总量汇聚实时统计数据检索失败"+ExceptionUtil.getExceptionMsg(e));
			throw new ServiceRuntimeException(auditLogThread, System.currentTimeMillis() - start,
					"业务总量汇聚实时统计数据检索失败:" + e.getMessage(), RestBusinessCode.service_runtime_error.getValue());
		}
		return serviceLogResponse(auditLogThread, System.currentTimeMillis() - start, request, "业务总量汇聚实时统计数据检索成功",list, 0);
	}
	/**
	 *  根据ip46,协议tcp，udp查询带宽
	 */
	@RequestMapping(value = "trafficBandwidthTrans", method = RequestMethod.GET)
	@ApiOperation(value = "带宽根据ip46,协议tcp,udp查询详情", httpMethod = "GET", notes = "对应带宽根据IPv4,6,协议tcp,udp统计数据显示")
	public Map<String,?> trafficBandwidthTrans(String addrType,Integer transType,Model model, 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<HashMap> resultList = dashboardService.getBandwidthTrans(addrType, transType);
			if (resultList!=null&&resultList.size() > 0) {
				list = resultList;
			}
		} catch (Exception e) {
			e.printStackTrace();
			auditLogThread.setExceptionInfo(e.getMessage() + " " + e.getCause());
			logger.error("带宽实时统计数据检索失败"+ExceptionUtil.getExceptionMsg(e));
			throw new ServiceRuntimeException(auditLogThread, System.currentTimeMillis() - start,
					"带宽实时统计数据检索失败:" + e.getMessage(), RestBusinessCode.service_runtime_error.getValue());
		}
		return serviceLogResponse(auditLogThread, System.currentTimeMillis() - start, request, "带宽实时统计数据检索成功",list, 0);
	}
	/**
	 * 流量统计活跃端口统计
	 */
	@RequestMapping(value = "trafficPortActive", method = RequestMethod.GET)
	@ApiOperation(value = "活跃端口统计", httpMethod = "GET", notes = "对应流量统计活跃端口统计")
	public Map<String,?> trafficPortActive(Model model, HttpServletRequest request, HttpServletResponse response) {
		
		long start = System.currentTimeMillis();
		AuditLogThread auditLogThread = super.saveRequestLog(servicesRequestLogService, Constants.OPACTION_GET, request, null);
		List<Map> list = new ArrayList<Map>();
		try {
			List<Map> resultList = dashboardService.getPortActiveList();
			if(resultList!=null&&resultList.size()>0) {
				list=resultList;
			}
			
		} catch (Exception e) {
			e.printStackTrace();
			auditLogThread.setExceptionInfo(e.getMessage() + " " + e.getCause());
			logger.error("活跃端口实时统计数据检索失败:"+ExceptionUtil.getExceptionMsg(e));
			throw new ServiceRuntimeException(auditLogThread, System.currentTimeMillis() - start,
					"活跃端口实时统计数据检索失败:" + e.getMessage(), RestBusinessCode.service_runtime_error.getValue());
		}
		return serviceLogResponse(auditLogThread, System.currentTimeMillis() - start, request, "活跃端口实时统计数据检索成功",list, 0);
	}
	
		
	/**
	 * 协议统计
	 */
	@RequestMapping(value="trafficProtocol", method = RequestMethod.GET)
	@ApiOperation(value = "协议统计", httpMethod = "GET", notes = "对应协议统计实时统计查询服务。")
	public Map<String,?> trafficProtocol(Model model, 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> ipActiveChart = dashboardService.protocolChart();
				if (ipActiveChart.size() > 0) {
					String jsonString = JsonMapper.toJsonString(ipActiveChart);
					list = (java.util.List<HashMap>) JsonMapper.fromJsonList(jsonString,HashMap.class);
			}
		} catch (Exception e) {
			e.printStackTrace();
			auditLogThread.setExceptionInfo(e.getMessage() + " " + e.getCause());
			logger.error("协议统计图表数据检索失败:"+ExceptionUtil.getExceptionMsg(e));
			throw new ServiceRuntimeException(auditLogThread, System.currentTimeMillis() - start,
					"协议统计图表数据检索失败:" + e.getMessage(), RestBusinessCode.service_runtime_error.getValue());
		}
		return serviceLogResponse(auditLogThread, System.currentTimeMillis() - start, request, "协议统计图表数据检索成功",
				list, 0);
	}
	/**
	 * 协议统计详情图与表
	 */
	@RequestMapping(value="trafficProtocolList", method = RequestMethod.GET)
	@ApiOperation(value = "协议统计占比与报表", httpMethod = "GET", notes = "对应协议统计详情占比与报表")
	public Map<String,?> trafficProtocolList(Model model, 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();
			if (ipActiveList.size() > 0) {
				String jsonString = JsonMapper.toJsonString(ipActiveList);
				list = (java.util.List<HashMap>) JsonMapper.fromJsonList(jsonString,HashMap.class);
			}
		} catch (Exception e) {
			e.printStackTrace();
			auditLogThread.setExceptionInfo(e.getMessage() + " " + e.getCause());
			logger.error("协议统计图表数据检索失败:"+ExceptionUtil.getExceptionMsg(e));
			throw new ServiceRuntimeException(auditLogThread, System.currentTimeMillis() - start,
					"协议统计图表数据检索失败:" + e.getMessage(), RestBusinessCode.service_runtime_error.getValue());
		}
		return serviceLogResponse(auditLogThread, System.currentTimeMillis() - start, request, "协议统计图表数据检索成功",
				list, 0);
	}
	
	
	/**
	 * 活跃IP TOP10
	 */
	@RequestMapping(value = "trafficIpActive", method = RequestMethod.GET)
	@ApiOperation(value = "活跃IP统计", httpMethod = "GET", notes = "对应活跃IP实时统计查询服务。")
	public Map<String,?> trafficIpActive(Model model, HttpServletRequest request, HttpServletResponse response) {

		long start = System.currentTimeMillis();
		AuditLogThread auditLogThread = super.saveRequestLog(servicesRequestLogService, Constants.OPACTION_GET, request, null);
		List<LinkedHashMap> list = new ArrayList<LinkedHashMap>();
		try {
			List<LinkedHashMap> ipActiveChart = dashboardService.ipActiveChart();
				if (ipActiveChart.size() > 0) {
					list = ipActiveChart;
			}
		} catch (Exception e) {
			e.printStackTrace();
			auditLogThread.setExceptionInfo(e.getMessage() + " " + e.getCause());
			logger.error("活跃IP实时统计数据检索失败:"+ExceptionUtil.getExceptionMsg(e));
			throw new ServiceRuntimeException(auditLogThread, System.currentTimeMillis() - start,
					"活跃IP实时统计数据检索失败:" + e.getMessage(), RestBusinessCode.service_runtime_error.getValue());
		}
		return serviceLogResponse(auditLogThread, System.currentTimeMillis() - start, request, "活跃IP实时统计数据检索成功",list, 0);
	}
	/**
	 * 活跃IP TOP10 一小时数据
	 */
	@RequestMapping(value = "trafficIpActiveOneHour", method = RequestMethod.GET)
	@ApiOperation(value = "活跃IP统计一个小时的活跃IP", httpMethod = "GET", notes = "对应活跃IP实时统计查询服务。")
	public Map<String,?> trafficIpActiveOneHour(Model model, 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<HashMap> ipActiveChart = dashboardService.ipActiveOneHour();
			if (ipActiveChart.size() > 0) {
				list = ipActiveChart;
			}
		} catch (Exception e) {
			e.printStackTrace();
			auditLogThread.setExceptionInfo(e.getMessage() + " " + e.getCause());
			logger.error("活跃IP统计一个小时的活跃IP"+ExceptionUtil.getExceptionMsg(e));
			throw new ServiceRuntimeException(auditLogThread, System.currentTimeMillis() - start,
					"活跃IP统计一个小时的活跃IP检索失败:" + e.getMessage(), RestBusinessCode.service_runtime_error.getValue());
		}
		return serviceLogResponse(auditLogThread, System.currentTimeMillis() - start, request, "活跃IP统计一个小时的活跃IP检索成功",list, 0);
	}
	/**
	 * 活跃IP TOP10 一小时数据
	 */
	@RequestMapping(value = "trafficIpActiveFiveMinute", method = RequestMethod.GET)
	@ApiOperation(value = "活跃IP最近一个小时的变化趋势统计", httpMethod = "GET", notes = "对最新TOP10的活跃IP，在近一个小时的变化情况进行统计")
	public Map<String,?> trafficIpActiveFiveMinute(Model model, 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<HashMap> ipActiveChart = dashboardService.ipActiveFiveMinute();
			if (ipActiveChart.size() > 0) {
				list = ipActiveChart;
			}
		} catch (Exception e) {
			e.printStackTrace();
			auditLogThread.setExceptionInfo(e.getMessage() + " " + e.getCause());
			logger.error("活跃IP最近一个小时的变化趋势统计"+ExceptionUtil.getExceptionMsg(e));
			throw new ServiceRuntimeException(auditLogThread, System.currentTimeMillis() - start,
					"活跃IP最近一个小时的变化趋势统计失败:" + e.getMessage(), RestBusinessCode.service_runtime_error.getValue());
		}
		return serviceLogResponse(auditLogThread, System.currentTimeMillis() - start, request, "活跃IP最近一个小时的变化趋势统计成功",list, 0);
	}
	/**
	 * app应用流量分析 TOP10
	 */
	@RequestMapping(value = "trafficApp", method = RequestMethod.GET)
	@ApiOperation(value = "App流量分析统计", httpMethod = "GET", notes = "对应app流量分析实时统计查询服务。")
	public Map<String, ?> trafficApp(Model model, HttpServletRequest request, HttpServletResponse response) {
		
		long start = System.currentTimeMillis();
		AuditLogThread auditLogThread = super.saveRequestLog(servicesRequestLogService, Constants.OPACTION_GET, request, null);
		List<Map> list = new ArrayList<Map>();
		try {
			List<Map> appChart = dashboardService.appChart();
			if (appChart.size() > 0) {
				list = appChart;
			}
		} catch (Exception e) {
			e.printStackTrace();
			auditLogThread.setExceptionInfo(e.getMessage() + " " + e.getCause());
			logger.error("App流量分析统计:"+ExceptionUtil.getExceptionMsg(e));
			throw new ServiceRuntimeException(auditLogThread, System.currentTimeMillis() - start,
					"App流量分析统计失败:" + e.getMessage(), RestBusinessCode.service_runtime_error.getValue());
		}
		return serviceLogResponse(auditLogThread, System.currentTimeMillis() - start, request, "App流量统计数据检索成功",list, 0);
	}
	@RequestMapping(value = "trafficOsList", method = RequestMethod.GET)
	@ApiOperation(value = "操作系统流量分析统计", httpMethod = "GET", notes = "对应终端用户的操作系统列表显示")
	public Map<String,?> trafficOsList(Model model, HttpServletRequest request, HttpServletResponse response) {
		long start = System.currentTimeMillis();
		AuditLogThread auditLogThread = super.saveRequestLog(servicesRequestLogService, Constants.OPACTION_GET, request, null);
		List<Map> list = new ArrayList<Map>();
		try {
			List<Map> osChart = dashboardService.systemList();
			if (osChart.size() > 0) {
				list = osChart;
			}
		} catch (Exception e) {
			e.printStackTrace();
			auditLogThread.setExceptionInfo(e.getMessage() + " " + e.getCause());
			logger.error("操作系统流量分析统计失败："+ExceptionUtil.getExceptionMsg(e));
			throw new ServiceRuntimeException(auditLogThread, System.currentTimeMillis() - start,
					"操作系统流量分析统计失败:" + e.getMessage(), RestBusinessCode.service_runtime_error.getValue());
		}
		return serviceLogResponse(auditLogThread, System.currentTimeMillis() - start, request, "操作系统流量分析统计检索成功",list, 0);
	}
	@RequestMapping(value = "trafficBrowserChart", method = RequestMethod.GET)
	@ApiOperation(value = "操作系统下浏览器流量分析统计", httpMethod = "GET", notes = "对应终端用户某个操作系统的浏览器分类统计显示")
	public Map<String, ?> trafficBrowserChart(Integer osType,Model model, HttpServletRequest request, HttpServletResponse response) {
		
		long start = System.currentTimeMillis();
		AuditLogThread auditLogThread = super.saveRequestLog(servicesRequestLogService, Constants.OPACTION_GET, request, null);
		List<Map> list = new ArrayList<Map>();
		try {
			List<Map> osChart = dashboardService.getBrowserBySystem(osType);
			if (osChart.size() > 0) {
				list=osChart;
			}
		} catch (Exception e) {
			e.printStackTrace();
			auditLogThread.setExceptionInfo(e.getMessage() + " " + e.getCause());
			logger.error("操作系统下浏览器流量分析统计失败："+e);
			throw new ServiceRuntimeException(auditLogThread, System.currentTimeMillis() - start,
					"操作系统下浏览器流量分析统计失败:" + e.getMessage(), RestBusinessCode.service_runtime_error.getValue());
		}
		return serviceLogResponse(auditLogThread, System.currentTimeMillis() - start, request, "操作系统下浏览器分类统计数据检索成功",list, 0);
	}
	@RequestMapping(value = "trafficBsList", method = RequestMethod.GET)
	@ApiOperation(value = "浏览器流量分析统计", httpMethod = "GET", notes = "对应终端用户的浏览器列表显示")
	public Map<String, ?> trafficBsList(Model model, HttpServletRequest request, HttpServletResponse response) {
		long start = System.currentTimeMillis();
		AuditLogThread auditLogThread = super.saveRequestLog(servicesRequestLogService, Constants.OPACTION_GET, request, null);
		List<Map> list = new ArrayList<Map>();
		try {
			List<Map> bsChart = dashboardService.browserList();
			if (bsChart.size() > 0) {
				list = bsChart;
			}
		} catch (Exception e) {
			e.printStackTrace();
			auditLogThread.setExceptionInfo(e.getMessage() + " " + e.getCause());
			logger.error("浏览器流量分析统计失败："+ExceptionUtil.getExceptionMsg(e));
			throw new ServiceRuntimeException(auditLogThread, System.currentTimeMillis() - start,
					"浏览器流量分析统计失败:" + e.getMessage(), RestBusinessCode.service_runtime_error.getValue());
		}
		return serviceLogResponse(auditLogThread, System.currentTimeMillis() - start, request, "浏览器流量分析统计数据检索成功",list, 0);
	}
	@RequestMapping(value = "trafficSystemChart", method = RequestMethod.GET)
	@ApiOperation(value = "浏览器下操作系统流量分析统计", httpMethod = "GET", notes = "对应终端用户某个浏览器的操作系统分类统计显示")
	public Map<String,?> trafficSystemChart(Integer bsType,Model model, HttpServletRequest request, HttpServletResponse response) {
		
		long start = System.currentTimeMillis();
		AuditLogThread auditLogThread = super.saveRequestLog(servicesRequestLogService, Constants.OPACTION_GET, request, null);
		List<Map> list = new ArrayList<Map>();
		try {
			List<Map> bsChart = dashboardService.getSystemBybrowser(bsType);
			if (bsChart.size() > 0) {
				list = bsChart;
			}
		} catch (Exception e) {
			e.printStackTrace();
			auditLogThread.setExceptionInfo(e.getMessage() + " " + e.getCause());
			logger.error("浏览器下操作系统流量分析统计失败："+ExceptionUtil.getExceptionMsg(e));
			throw new ServiceRuntimeException(auditLogThread, System.currentTimeMillis() - start,
					"浏览器下操作系统流量分析统计失败:" + e.getMessage(), RestBusinessCode.service_runtime_error.getValue());
		}
		return serviceLogResponse(auditLogThread, System.currentTimeMillis() - start, request, "浏览器下操作系统流量统计数据检索成功",list, 0);
	}
	@RequestMapping(value = "trafficWebsiteList", method = RequestMethod.GET)
	@ApiOperation(value = "网站流量分析统计", httpMethod = "GET", notes = "对应网站http分类显示")
	public Map<String,?> trafficWebsiteList(Model model, HttpServletRequest request, HttpServletResponse response) {
		
		long start = System.currentTimeMillis();
		AuditLogThread auditLogThread = super.saveRequestLog(servicesRequestLogService, Constants.OPACTION_GET, request, null);
		List<Map> list = new ArrayList<Map>();
		try {
//			List<Map> websiteChart = dashboardService.websiteList();
			List<Map> websiteChart = dashboardService.getDomainByWebsiteList();
			if (websiteChart.size() > 0) {
				list = websiteChart;
			}
		} catch (Exception e) {
			e.printStackTrace();
			auditLogThread.setExceptionInfo(e.getMessage() + " " + e.getCause());
			logger.error("网站流量分析统计失败："+ExceptionUtil.getExceptionMsg(e));
			throw new ServiceRuntimeException(auditLogThread, System.currentTimeMillis() - start,
					"网站流量分析统计失败:" + e.getMessage(), RestBusinessCode.service_runtime_error.getValue());
		}
		return serviceLogResponse(auditLogThread, System.currentTimeMillis() - start, request, "网站流量分析统计数据检索成功",list, 0);
	}
	@RequestMapping(value = "trafficWebTypeChart", method = RequestMethod.GET)
	@ApiOperation(value = "HTTP网站分类分析统计", httpMethod = "GET", notes = "对应某个网站类型分类统计图")
	public Map<String, ?> trafficWebTypeChart(Integer websiteServiceId,Model model, HttpServletRequest request, HttpServletResponse response) {
		
		long start = System.currentTimeMillis();
		AuditLogThread auditLogThread = super.saveRequestLog(servicesRequestLogService, Constants.OPACTION_GET, request, null);
		List<Map> list = new ArrayList<Map>();
		try {
			List<Map> websiteChart = dashboardService.getDomainByWebsiteServiceId(websiteServiceId);
			if (websiteChart.size() > 0) {
				list = websiteChart;
			}
		} catch (Exception e) {
			e.printStackTrace();
			auditLogThread.setExceptionInfo(e.getMessage() + " " + e.getCause());
			logger.error("HTTP网站分类分析统计失败："+e);
			throw new ServiceRuntimeException(auditLogThread, System.currentTimeMillis() - start,
					"HTTP网站分类分析统计失败:" + e.getMessage(), RestBusinessCode.service_runtime_error.getValue());
		}
		return serviceLogResponse(auditLogThread, System.currentTimeMillis() - start, request, "HTTP网站分类分析统计成功",list, 0);
	}
	@RequestMapping(value = "trafficTopicAndDomainChart", method = RequestMethod.GET)
	@ApiOperation(value = "HTTP网站主题分类分析统计", httpMethod = "GET", notes = "对应某个网站主题类型分类统计图")
	public Map<String, ?> trafficTopicAndDomainChart(Integer websiteServiceId,Model model, HttpServletRequest request, HttpServletResponse response) {
		
		long start = System.currentTimeMillis();
		AuditLogThread auditLogThread = super.saveRequestLog(servicesRequestLogService, Constants.OPACTION_GET, request, null);
		List<Map> list = new ArrayList<Map>();
		try {
			List<Map> websiteChart = dashboardService.getTopicAndDomainList();
			if (websiteChart.size() > 0) {
				list = websiteChart;
			}
		} catch (Exception e) {
			e.printStackTrace();
			auditLogThread.setExceptionInfo(e.getMessage() + " " + e.getCause());
			logger.error("HTTP网站主题分类分析统计失败："+ExceptionUtil.getExceptionMsg(e));
			throw new ServiceRuntimeException(auditLogThread, System.currentTimeMillis() - start,
					"HTTP网站分类分析统计失败:" + e.getMessage(), RestBusinessCode.service_runtime_error.getValue());
		}
		return serviceLogResponse(auditLogThread, System.currentTimeMillis() - start, request, "HTTP网站主题分类分析数据检索成功",list, 0);
	}
}