package com.slave.midScreen.controller; import com.github.pagehelper.PageInfo; import com.rockstar.frame.model.extend.TableSplitResult; import com.rockstar.frame.model.extend.Tablepar; import com.slave.midScreen.model.in.SelectFenXi; import com.slave.midScreen.model.in.SelectInfo; import com.slave.midScreen.model.in.SelectInfoDetail; import com.slave.midScreen.service.SecuritySupervisService; import com.slave2.midScreen2.service.SecuritySupervis2Service; import io.swagger.annotations.Api; import org.apache.ibatis.annotations.Param; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.ResponseBody; import java.util.*; /** * 中屏_安全监管和行业通报信息 */ @Controller @RequestMapping(value = "/SecuritySuperviseController") @Api(value = "中屏_安全监管") public class SecuritySuperviseController { @Autowired private SecuritySupervisService securitySupervisService; @Autowired private SecuritySupervis2Service securitySupervis2Service; // @PostMapping(value = "test",produces = {"application/json;charset=UTF-8"}) // @ResponseBody // public Object listAll(DemoStudent model){ // return "hello world"; // } /** * 风险数量列表查询 * * @param info * @return */ @PostMapping(value = "findRiskCountList", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findRiskCountList(Map info) { return securitySupervis2Service.findRiskCountList(info); } /** * 风险超过24小时的数量查询 * * @param info * @return */ @PostMapping(value = "findOverHourRiskCountList", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findOverHourRiskCountList(Map info) { return securitySupervis2Service.findOverHourRiskCountList(info); } /** * 隐患数量列表查询 * * @param info * @return */ @PostMapping(value = "findTroubleCountList", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findTroubleCountList(Map info) { return securitySupervisService.findTroubleCountList(info); } /** * 隐患超过24小时的数量查询 * * @param info * @return */ @PostMapping(value = "findOverHourTroubleCountList", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findOverHourTroubleCountList(Map info) { return securitySupervisService.findOverHourTroubleCountList(info); } /** * 突发事件数量列表查询 * * @param info * @return */ @PostMapping(value = "findEmergencyCountList", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findEmergencyCountList(Map info) { return securitySupervisService.findEmergencyCountList(info); } /** * 突发事件超过24小时的数量查询 * * @param info * @return */ @PostMapping(value = "findOverHourEmergencyCountList", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findOverHourEmergencyCountList(Map info) { return securitySupervisService.findOverHourEmergencyCountList(info); } /** * 总统计各个区/县级市的风险数量 * * @param info * @return */ @PostMapping(value = "findCountEveryPlace", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findCountEveryPlace(SelectInfo info) { // 统计的大类选择 1风险统计,2在发隐患统计,3突发事件统计 String top_type = info.getTop_type(); // 各个统计大类的子统计数据 String second_type = info.getSecond_type(); if (second_type != null && !"".equals(second_type.toString())) { String[] split = second_type.toString().split(","); info.setSecond_typeList(Arrays.asList(split)); } // 各个统计大类的子统计数据 String grade = info.getGrade(); if (grade != null && !"".equals(grade.toString())) { String[] split = grade.toString().split(","); info.setGradeList(Arrays.asList(split)); } // 统计的大类选择 1风险统计,2在发隐患统计,3突发事件统计 if ("1".equals(top_type)) { return securitySupervis2Service.findCountRiskEveryPlace(info); } else if ("2".equals(top_type)) { return securitySupervisService.findCountTroubleEveryPlace(info); } else if ("3".equals(top_type)) { return securitySupervisService.findCountEmergencyEveryPlace(info); } else { return null; } } /** * 总统计各个区/县级市的风险信息(查询的涂层点信息语句) * * @param info * @return */ @PostMapping(value = "findInfoEveryPlace", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findInfoEveryPlace(SelectInfo info) { // 统计的大类选择 1风险统计,2在发隐患统计,3突发事件统计 String top_type = info.getTop_type(); // 各个统计大类的子统计数据 String second_type = info.getSecond_type(); if (second_type != null && !"".equals(second_type.toString())) { String[] split = second_type.toString().split(","); info.setSecond_typeList(Arrays.asList(split)); } // 统计的大类选择 1风险统计,2在发隐患统计,3突发事件统计 if ("1".equals(top_type)) { return securitySupervis2Service.findInfoRiskEveryPlace(info); } else if ("2".equals(top_type)) { return securitySupervisService.findInfoTroubleEveryPlace(info); } else if ("3".equals(top_type)) { return securitySupervisService.findInfoEmergencyEveryPlace(info); } else { return null; } } /** * 各个风险数据 区/县级市的风险信息 * * @param info * @return */ @PostMapping(value = "findInfoDetailEveryPlace", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findInfoDetailEveryPlace(SelectInfoDetail info, Tablepar tablepar) { // 统计的大类选择 1风险统计,2在发隐患统计,3突发事件统计 String top_type = info.getTop_type(); // 各个统计大类的子统计数据 String second_type = info.getSecond_type(); String places = info.getPlaces(); if (places != null && !"".equals(places.toString())) { String[] split = places.split(","); info.setPlacesList(Arrays.asList(split)); } String levels = info.getLevels(); if (levels != null && !"".equals(levels.toString())) { String[] split = levels.split(","); info.setLevelsList(Arrays.asList(split)); } String isOften = info.getIsOften(); if (isOften != null && !"".equals(isOften.toString())) { String[] split = isOften.split(","); info.setIsOftenList(Arrays.asList(split)); } String disposeProgress = info.getDisposeProgress(); if (disposeProgress != null && !"".equals(disposeProgress.toString())) { String[] split = disposeProgress.split(","); info.setDisposeProgressList(Arrays.asList(split)); } String isTimeout = info.getIsTimeout(); String type = info.getType(); if (type != null && !"".equals(type.toString())) { String[] split = type.split(","); info.setTypeList(Arrays.asList(split)); } // 统计的大类选择 1风险统计,2在发隐患统计,3突发事件统计 if ("1".equals(top_type)) { if (isTimeout != null && !"".equals(isTimeout.toString())) { String[] split = isTimeout.split(","); info.setIsTimeoutList(Arrays.asList(split)); ArrayList strings = new ArrayList<>(); for (int i = 0; i < split.length; i++) { if (split[i].equals("是")) { // --超时24小时 strings.add("EXTRACT (EPOCH FROM (now()-pgsj))> (24*60*60)"); } else if (split[i].equals("否")) { // --不超时24小时 strings.add("EXTRACT (EPOCH FROM (now()-pgsj)) <= (24*60*60)"); } } info.setIsTimeoutList(strings); } // return securitySupervis2Service.findInfoRiskDetailEveryPlace(info); PageInfo> page = securitySupervis2Service.findInfoRiskDetailEveryPlace(tablepar, info); TableSplitResult> result = new TableSplitResult<>(page.getPageNum(), page.getTotal(), page.getList()); return result; } else if ("2".equals(top_type)) { if (isTimeout != null && !"".equals(isTimeout.toString())) { String[] split = isTimeout.split(","); info.setIsTimeoutList(Arrays.asList(split)); ArrayList strings = new ArrayList<>(); for (int i = 0; i < split.length; i++) { if (split[i].equals("是")) { // --超时24小时 strings.add("EXTRACT (EPOCH FROM (now()-find_time))> (24*60*60)"); } else if (split[i].equals("否")) { // --不超时24小时 strings.add("EXTRACT (EPOCH FROM (now()-find_time)) <= (24*60*60)"); } } info.setIsTimeoutList(strings); } // return securitySupervisService.findInfoTroubleDetailEveryPlace(info); PageInfo> page = securitySupervisService.findInfoTroubleDetailEveryPlace(tablepar, info); TableSplitResult> result = new TableSplitResult<>(page.getPageNum(), page.getTotal(), page.getList()); return result; } else if ("3".equals(top_type)) { if (isTimeout != null && !"".equals(isTimeout.toString())) { String[] split = isTimeout.split(","); info.setIsTimeoutList(Arrays.asList(split)); ArrayList strings = new ArrayList<>(); for (int i = 0; i < split.length; i++) { if (split[i].equals("是")) { // --超时24小时 strings.add("EXTRACT (EPOCH FROM (now()-find_time))> (24*60*60)"); } else if (split[i].equals("否")) { // --不超时24小时 strings.add("EXTRACT (EPOCH FROM (now()-find_time)) <= (24*60*60)"); } } info.setIsTimeoutList(strings); } // return securitySupervisService.findInfoEmergencyDetailEveryPlace(info); PageInfo> page = securitySupervisService.findInfoEmergencyDetailEveryPlace(tablepar, info); TableSplitResult> result = new TableSplitResult<>(page.getPageNum(), page.getTotal(), page.getList()); return result; } else { return null; } } /** * 综合监管_行业通报查询列表 * * @param * @return */ @PostMapping(value = "findHangYeTongBaoList", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findHangYeTongBaoList(Integer year, String scene) { return securitySupervisService.findHangYeTongBaoList(year, scene); } /** * 综合监管_行业评价_行业评价查询 * * @param * @return */ @PostMapping(value = "findHangYePingJiaList", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findHangYePingJiaList(String scene) { return securitySupervisService.findHangYePingJiaList(scene); } /** * 综合监管_案例分析_案例分析查询 * * @param * @return */ @PostMapping(value = "findAnLiFenXiList", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findAnLiFenXiList(Integer year, String scene) { return securitySupervisService.findAnLiFenXiList(year, scene); } //===================================================================================================================================================================================================== //大屏左边第二个下边 突发事件处置率,已上报,已处置 @PostMapping(value = "findShiJianChuZhiCount", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findShiJianChuZhiCount(String year) { String sql = "SELECT \n" + "count(1) all_count, --风险总数\n" + "count(1) filter(where dispose_progress in('2')) as has_close_count --已处置总数\n" + "FROM zhjg_analysis_emergency\n" + "where \n" + "EXTRACT ( YEAR FROM find_time ) = " + year; return securitySupervisService.select1(sql); } /** * 综合监管 事件分析 事件档案列表(7种情况都可以)++ * * @param * @return */ @PostMapping(value = "findShiJianFenXi", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findShiJianFenXi(Tablepar tablepar, SelectFenXi info) { String places = info.getPlaces(); if (places != null && !"".equals(places.toString())) { String[] split = places.split(","); info.setPlacesList(Arrays.asList(split)); } String levels = info.getLevels(); if (levels != null && !"".equals(levels.toString())) { String[] split = levels.split(","); info.setLevelsList(Arrays.asList(split)); } String isOften = info.getIsOften(); if (isOften != null && !"".equals(isOften.toString())) { String[] split = isOften.split(","); info.setIsOftenList(Arrays.asList(split)); } // String disposeProgress = info.getDisposeProgress(); // if (disposeProgress != null && !"".equals(disposeProgress.toString())) { // String[] split = disposeProgress.split(","); // info.setDisposeProgressList(Arrays.asList(split)); // } String types = info.getTypes(); if (types != null && !"".equals(types.toString())) { String[] split = types.split(","); info.setTypesList(Arrays.asList(split)); } PageInfo> page = securitySupervisService.findShiJianFenXi(tablepar, info); TableSplitResult> result = new TableSplitResult<>(page.getPageNum(), page.getTotal(), page.getList()); return result; } /** * 综合监管 事件分析 中间页面:突发事件等级统计 事件(待处理,已处理都要)分析统计++ * * @param * @return */ @PostMapping(value = "findShiJianFenXiTongJi", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findShiJianFenXiTongJi(Integer year, String scene) { Calendar calendar = Calendar.getInstance(); int year2 = calendar.get(Calendar.YEAR); Date start_time = null; Date end_time = null; if (year == year2) { end_time = calendar.getTime(); calendar.add(Calendar.MONTH, -11); calendar.set(calendar.get(Calendar.YEAR), calendar.get(Calendar.MONTH), 1, 0, 0, 0); calendar.set(Calendar.MILLISECOND, 0); start_time = calendar.getTime(); } else { calendar.set(year, 1, 1, 0, 0, 0); calendar.set(Calendar.MILLISECOND, 0); start_time = calendar.getTime(); calendar.set(year + 1, 1, 1, 0, 0, 0); end_time = calendar.getTime(); } return securitySupervisService.findShiJianFenXiTongJi(start_time, end_time, scene); } /** * 综合监管 事件分析 中间页面:突发事件等级统计 事件(待处理,已处理都要)分析统计++ * * @param * @return */ @PostMapping(value = "findShiJianFenXiTongJiOfYear", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findShiJianFenXiTongJiOfYear(Integer year) { Calendar calendar = Calendar.getInstance(); int year2 = calendar.get(Calendar.YEAR); Date start_time = null; Date end_time = null; if (year == year2) { end_time = calendar.getTime(); calendar.add(Calendar.MONTH, -11); calendar.set(calendar.get(Calendar.YEAR), calendar.get(Calendar.MONTH), 1, 0, 0, 0); calendar.set(Calendar.MILLISECOND, 0); start_time = calendar.getTime(); } else { calendar.set(year, 1, 1, 0, 0, 0); calendar.set(Calendar.MILLISECOND, 0); start_time = calendar.getTime(); calendar.set(year + 1, 1, 1, 0, 0, 0); end_time = calendar.getTime(); } return securitySupervisService.findShiJianFenXiTongJiOfYear(start_time, end_time); } /** * 综合监管 事件分析 右边页面:突发事件等级统计 事件(待处理,已处理都要)分析统计2 ,分区县统计++ * * @param * @return */ @PostMapping(value = "findShiJianFenXiTongJi2", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findShiJianFenXiTongJi2(Integer year, String scene) { return securitySupervisService.findShiJianFenXiTongJi2(year, scene); } /** * 综合监管 事件分析 右边页面:突发事件等级统计 事件(待处理,已处理都要)分析统计3 ,分月份获取各个等级的数量++ * * @param place 区县的选择 * @return */ @PostMapping(value = "findShiJianFenXiTongJi3", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findShiJianFenXiTongJi3(Integer year, String place, String scene) { return securitySupervisService.findShiJianFenXiTongJi3(year, place, scene); } /** * 综合监管 事件分析 右边页面:突发事件等级统计 事件(待处理,已处理都要)分析统计4 ,分月份获取各个已处置的事件数量++ * * @param place 区县的选择 * @return */ @PostMapping(value = "findShiJianFenXiTongJi4", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findShiJianFenXiTongJi4(Integer year, String place, String scene) { return securitySupervisService.findShiJianFenXiTongJi4(year, place, scene); } /** * 综合监管 隐患分析 隐患档案列表_隐患分析_第三方++ 同findYinHuanFenXiOther * * @param * @return */ // @PostMapping(value = "findYinHuanFenXi", produces = {"application/json;charset=UTF-8"}) // @ResponseBody // public Object findYinHuanFenXi(Tablepar tablepar, SelectFenXi info) { // PageInfo> page = securitySupervisService.findYinHuanFenXi(tablepar, info); // TableSplitResult> result = new TableSplitResult<>(page.getPageNum(), page.getTotal(), page.getList()); // return result; // } /** * 综合监管 隐患分析 隐患档案列表_隐患分析_燃气_供水_排水++ * * @param * @return */ @PostMapping(value = "findYinHuanFenXiOther", produces = {"application/json;charset=UTF-8"}) @ResponseBody public TableSplitResult> findYinHuanFenXiOther(Tablepar tablepar, SelectFenXi info) { String places = info.getPlaces(); if (places != null && !"".equals(places.toString())) { String[] split = places.split(","); info.setPlacesList(Arrays.asList(split)); } String levels = info.getLevels(); if (levels != null && !"".equals(levels.toString())) { String[] split = levels.split(","); info.setLevelsList(Arrays.asList(split)); } String isOften = info.getIsOften(); if (isOften != null && !"".equals(isOften.toString())) { String[] split = isOften.split(","); info.setIsOftenList(Arrays.asList(split)); } // String disposeProgress = info.getDisposeProgress(); // if (disposeProgress != null && !"".equals(disposeProgress.toString())) { // String[] split = disposeProgress.split(","); // info.setDisposeProgressList(Arrays.asList(split)); // } String types = info.getTypes(); if (types != null && !"".equals(types.toString())) { String[] split = types.split(","); info.setTypesList(Arrays.asList(split)); } PageInfo> page = securitySupervisService.findYinHuanFenXiOther(tablepar, info); TableSplitResult> result = new TableSplitResult<>(page.getPageNum(), page.getTotal(), page.getList()); return result; } /** * 综合监管 隐患分析 中间页面:隐患等级统计 隐患(待处理,已处理都要)分析统计_第三方++ * * @param * @return */ @PostMapping(value = "findYinHuanFenXiTongJi", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findYinHuanFenXiTongJi(Integer year, String scene) { return securitySupervisService.findYinHuanFenXiTongJi(year, scene); } /** * 综合监管 隐患分析 中间页面:隐患等级统计 隐患(待处理,已处理都要)分析统计_燃气_供水_排水++ * * @param * @return */ @PostMapping(value = "findYinHuanFenXiOtherTongJi", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findYinHuanFenXiOtherTongJi(Integer year, String scene) { Calendar calendar = Calendar.getInstance(); int year2 = calendar.get(Calendar.YEAR); Date start_time = null; Date end_time = null; if (year == year2) { end_time = calendar.getTime(); calendar.add(Calendar.MONTH, -11); calendar.set(calendar.get(Calendar.YEAR), calendar.get(Calendar.MONTH), 1, 0, 0, 0); calendar.set(Calendar.MILLISECOND, 0); start_time = calendar.getTime(); } else { calendar.set(year, 1, 1, 0, 0, 0); calendar.set(Calendar.MILLISECOND, 0); start_time = calendar.getTime(); calendar.set(year + 1, 1, 1, 0, 0, 0); end_time = calendar.getTime(); } return securitySupervisService.findYinHuanFenXiOtherTongJi(start_time, end_time, scene); } @PostMapping(value = "findYinHuanFenXiOtherTongJiOfYear", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findYinHuanFenXiOtherTongJiOfYear(Integer year) { Calendar calendar = Calendar.getInstance(); int year2 = calendar.get(Calendar.YEAR); Date start_time = null; Date end_time = null; if (year == year2) { end_time = calendar.getTime(); calendar.add(Calendar.MONTH, -11); calendar.set(calendar.get(Calendar.YEAR), calendar.get(Calendar.MONTH), 1, 0, 0, 0); calendar.set(Calendar.MILLISECOND, 0); start_time = calendar.getTime(); } else { calendar.set(year, 1, 1, 0, 0, 0); calendar.set(Calendar.MILLISECOND, 0); start_time = calendar.getTime(); calendar.set(year + 1, 1, 1, 0, 0, 0); end_time = calendar.getTime(); } return securitySupervisService.findYinHuanFenXiOtherTongJiOfYear(start_time, end_time); } /** * 综合监管 隐患分析 右边页面:隐患等级统计 隐患(待处理,已处理都要)分析统计2,分区县统计_第三方++ * * @param * @return */ @PostMapping(value = "findYinHuanFenXiTongJi2", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findYinHuanFenXiTongJi2(Integer year, String scene) { return securitySupervisService.findYinHuanFenXiTongJi2(year, scene); } /** * 综合监管 隐患分析 右边页面:隐患等级统计 隐患(待处理,已处理都要)分析统计2,分区县统计_燃气_供水_排水++ * * @param * @return */ @PostMapping(value = "findYinHuanFenXiOtherTongJi2", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findYinHuanFenXiOtherTongJi2(Integer year, String scene) { return securitySupervisService.findYinHuanFenXiOtherTongJi2(year, scene); } /** * 综合监管 隐患分析 右边页面:隐患等级统计 事件(待处理,已处理都要)分析统计3 ,分月份获取各个等级的数量_第三方++ * * @param place 区县的选择 * @return */ @PostMapping(value = "findYinHuanFenXiTongJi3", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findYinHuanFenXiTongJi3(Integer year, String place, String scene) { return securitySupervisService.findYinHuanFenXiTongJi3(year, place, scene); } /** * 综合监管 隐患分析 右边页面:隐患等级统计 事件(待处理,已处理都要)分析统计3 ,分月份获取各个等级的数量_燃气_供水_排水++ * * @param place 区县的选择 * @return */ @PostMapping(value = "findYinHuanFenXiOtherTongJi3", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findYinHuanFenXiOtherTongJi3(Integer year, String place, String scene, String grade) { return securitySupervisService.findYinHuanFenXiOtherTongJi3(year, place, scene, grade); } /** * 综合监管 隐患分析 右边页面:隐患等级统计 事件(待处理,已处理都要)分析统计4 ,分月份获取各个已处置的事件数量_第三方++ *

* 没有完成的数据 * * @param place 区县的选择 * @return */ @PostMapping(value = "findYinHuanFenXiTongJi4", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findYinHuanFenXiTongJi4(Integer year, String place, String scene) { return securitySupervisService.findYinHuanFenXiTongJi4(year, place, scene); } /** * 综合监管 隐患分析 右边页面:隐患等级统计 事件(待处理,已处理都要)分析统计4 ,分月份获取各个已处置的事件数量_燃气,供水,排水++ * * @param place 区县的选择 * @return */ @PostMapping(value = "findYinHuanFenXiOtherTongJi4", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findYinHuanFenXiOtherTongJi4(Integer year, String place, String scene) { return securitySupervisService.findYinHuanFenXiOtherTongJi4(year, place, scene); } /** * 综合监管 事件分析 -第三方 ,左边屏幕第三方施工破坏事件类别分析++ * * @param year 选择年份 */ @PostMapping(value = "findShiJIanFenXiDi3Fang", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findShiJIanFenXiDi3Fang(int year, String scene) { String sql = "SELECT COUNT\n" + "\t( 1 ) all_count,\n" + "\tCOUNT ( * ) FILTER ( WHERE EXTRACT ( MONTH FROM find_time ) = 1 ) AS month1,\n" + "\tCOUNT ( * ) FILTER ( WHERE EXTRACT ( MONTH FROM find_time ) = 2 ) AS month2,\n" + "\tCOUNT ( * ) FILTER ( WHERE EXTRACT ( MONTH FROM find_time ) = 3 ) AS month3,\n" + "\tCOUNT ( * ) FILTER ( WHERE EXTRACT ( MONTH FROM find_time ) = 4 ) AS month4,\n" + "\tCOUNT ( * ) FILTER ( WHERE EXTRACT ( MONTH FROM find_time ) = 5 ) AS month5,\n" + "\tCOUNT ( * ) FILTER ( WHERE EXTRACT ( MONTH FROM find_time ) = 6 ) AS month6,\n" + "\tCOUNT ( * ) FILTER ( WHERE EXTRACT ( MONTH FROM find_time ) = 7 ) AS month7,\n" + "\tCOUNT ( * ) FILTER ( WHERE EXTRACT ( MONTH FROM find_time ) = 8 ) AS month8,\n" + "\tCOUNT ( * ) FILTER ( WHERE EXTRACT ( MONTH FROM find_time ) = 9 ) AS month9,\n" + "\tCOUNT ( * ) FILTER ( WHERE EXTRACT ( MONTH FROM find_time ) = 10 ) AS month10,\n" + "\tCOUNT ( * ) FILTER ( WHERE EXTRACT ( MONTH FROM find_time ) = 11 ) AS month11,\n" + "\tCOUNT ( * ) FILTER ( WHERE EXTRACT ( MONTH FROM find_time ) = 12 ) AS month12,\n" + "\tT.relevance_facility_one \n" + "FROM\n" + "\t( SELECT regexp_split_to_table( zhjg_analysis_emergency.relevance_facility, ',' ) AS relevance_facility_one, zhjg_analysis_emergency.* FROM zhjg_analysis_emergency WHERE scene IN ( '" + scene + "' ) ) AS T \n" + "WHERE\n" + "\tEXTRACT ( YEAR FROM T.find_time ) = " + year + " \n" + "GROUP BY\n" + "\tT.relevance_facility_one"; return securitySupervisService.select1(sql); // Calendar calendar = Calendar.getInstance(); // int year2 = calendar.get(Calendar.YEAR); // Date start_time = null; // Date end_time = null; // if (year == year2) { // end_time = calendar.getTime(); // calendar.add(Calendar.MONTH, -11); // calendar.set(calendar.get(Calendar.YEAR), calendar.get(Calendar.MONTH), 1, 0, 0, 0); // calendar.set(Calendar.MILLISECOND, 0); // start_time = calendar.getTime(); // } else { // calendar.set(year, 1, 1, 0, 0, 0); // calendar.set(Calendar.MILLISECOND, 0); // start_time = calendar.getTime(); // calendar.set(year + 1, 1, 1, 0, 0, 0); // end_time = calendar.getTime(); // } // // return securitySupervisService.findShiJIanFenXiDi3Fang(start_time, end_time, scene); } /** * 综合监管 事件分析 -第三方 ,左边屏幕第三方施工破坏事件类别分析++ 类别统计 * * @param year 选择年份 */ @PostMapping(value = "findShiJIanFenXiDi3FangOfType", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findShiJIanFenXiDi3FangOfType(int year, String scene) { String sql = "SELECT COUNT\n" + "\t( 1 ) all_count,\n" + "\tT.relevance_facility_one \n" + "FROM\n" + "\t( SELECT regexp_split_to_table( zhjg_analysis_emergency.relevance_facility, ',' ) AS relevance_facility_one, zhjg_analysis_emergency.* FROM zhjg_analysis_emergency WHERE scene IN ( '" + scene + "' ) ) AS T \n" + "WHERE\n" + "\tEXTRACT ( YEAR FROM T.find_time ) = " + year + " \n" + "GROUP BY\n" + "\tT.relevance_facility_one"; return securitySupervisService.select1(sql); } /** * 综合监管 事件分析 中间页面:事件等级统计 事件(待处理,已处理都要)分析统计 * * @param * @return */ @PostMapping(value = "findShiJIanFenXiDi3FangTongJiLeft", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findShiJIanFenXiDi3FangTongJiLeft(Integer year, String scene) { return securitySupervisService.findShiJIanFenXiDi3FangTongJiLeft(year, scene); } @PostMapping(value = "findShiJIanFenXiDi3FangTongJiRight", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findShiJIanFenXiDi3FangTongJiRight(Integer year, String scene) { return securitySupervisService.findShiJIanFenXiDi3FangTongJiRight(year, scene); } /** * 综合监管 事件分析 右边页面:事件等级统计 事件(待处理,已处理都要)分析统计2,分区县统计 * * @param * @return */ @PostMapping(value = "findShiJIanFenXiDi3FangTongJi2", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findShiJIanFenXiDi3FangTongJi2(Integer year, String scene) { return securitySupervisService.findShiJIanFenXiDi3FangTongJi2(year, scene); } /** * 综合监管 事件分析 右边页面:事件等级统计 事件(待处理,已处理都要)分析统计3 ,分月份获取各个等级的数量 * * @param place 区县的选择 * @return */ @PostMapping(value = "findShiJIanFenXiDi3FangTongJi3", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findShiJIanFenXiDi3FangTongJi3(Integer year, String place, String scene) { return securitySupervisService.findShiJIanFenXiDi3FangTongJi3(year, place, scene); } /** * 综合监管 事件分析 右边页面:事件等级统计 事件(待处理,已处理都要)分析统计4 ,分月份获取各个已处置的事件数量 * * @param place 区县的选择 * @return */ @PostMapping(value = "findShiJIanFenXiDi3FangTongJi4", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findShiJIanFenXiDi3FangTongJi4(Integer year, String place, String scene) { return securitySupervisService.findShiJIanFenXiDi3FangTongJi4(year, place, scene); } /** *综合监管 风险分析 _ 道路选项的左边档案数据界面接口 * @param info * @return */ @PostMapping(value = "findFengXianHistoryList", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findFengXianHistoryList(Tablepar tablepar, SelectFenXi info) { String places = info.getPlaces(); if (places != null && !"".equals(places.toString())) { String[] split = places.split(","); info.setPlacesList(Arrays.asList(split)); } String levels = info.getLevels(); if (levels != null && !"".equals(levels.toString())) { String[] split = levels.split(","); info.setLevelsList(Arrays.asList(split)); } String isOften = info.getIsOften(); if (isOften != null && !"".equals(isOften.toString())) { String[] split = isOften.split(","); info.setIsOftenList(Arrays.asList(split)); } String types = info.getTypes(); if (types != null && !"".equals(types.toString())) { String[] split = types.split(","); info.setTypesList(Arrays.asList(split)); } // String sql ="SELECT * FROM archives_risk where del_flag=1"; PageInfo> page = securitySupervisService.findFengXianHistoryList(tablepar, info); TableSplitResult> result = new TableSplitResult<>(page.getPageNum(), page.getTotal(), page.getList()); return result; } /** * 综合监管 风险分析++ * * @param year 选择年份 */ @PostMapping(value = "findFengXianFenXi", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findFengXianFenXi(int year, String scene) { String sql = "SELECT COUNT\n" + "\t( 1 ) all_count,\n" + "\tCOUNT ( * ) FILTER ( WHERE EXTRACT ( MONTH FROM pgsj ) = 1 ) AS month1,\n" + "\tCOUNT ( * ) FILTER ( WHERE EXTRACT ( MONTH FROM pgsj ) = 2 ) AS month2,\n" + "\tCOUNT ( * ) FILTER ( WHERE EXTRACT ( MONTH FROM pgsj ) = 3 ) AS month3,\n" + "\tCOUNT ( * ) FILTER ( WHERE EXTRACT ( MONTH FROM pgsj ) = 4 ) AS month4,\n" + "\tCOUNT ( * ) FILTER ( WHERE EXTRACT ( MONTH FROM pgsj ) = 5 ) AS month5,\n" + "\tCOUNT ( * ) FILTER ( WHERE EXTRACT ( MONTH FROM pgsj ) = 6 ) AS month6,\n" + "\tCOUNT ( * ) FILTER ( WHERE EXTRACT ( MONTH FROM pgsj ) = 7 ) AS month7,\n" + "\tCOUNT ( * ) FILTER ( WHERE EXTRACT ( MONTH FROM pgsj ) = 8 ) AS month8,\n" + "\tCOUNT ( * ) FILTER ( WHERE EXTRACT ( MONTH FROM pgsj ) = 9 ) AS month9,\n" + "\tCOUNT ( * ) FILTER ( WHERE EXTRACT ( MONTH FROM pgsj ) = 10 ) AS month10,\n" + "\tCOUNT ( * ) FILTER ( WHERE EXTRACT ( MONTH FROM pgsj ) = 11 ) AS month11,\n" + "\tCOUNT ( * ) FILTER ( WHERE EXTRACT ( MONTH FROM pgsj ) = 12 ) AS month12,\n" + "\tT.fxlx \n" + "FROM\n" + "\tcitylifeline.view_risk_collect T \n" + "WHERE\n" + "\tEXTRACT ( YEAR FROM T.pgsj ) = " + year + " \n" + "\tAND T.TYPE IN ( '" + scene + "' ) \n" + "GROUP BY\n" + "\tT.fxlx \n" + "ORDER BY\n" + "\tT.fxlx"; return securitySupervis2Service.select2(sql); // Calendar calendar = Calendar.getInstance(); // int year2 = calendar.get(Calendar.YEAR); // Date start_time = null; // Date end_time = null; // if (year == year2) { // end_time = calendar.getTime(); // calendar.add(Calendar.MONTH, -11); // calendar.set(calendar.get(Calendar.YEAR), calendar.get(Calendar.MONTH), 1, 0, 0, 0); // calendar.set(Calendar.MILLISECOND, 0); // start_time = calendar.getTime(); // } else { // calendar.set(year, 1, 1, 0, 0, 0); // calendar.set(Calendar.MILLISECOND, 0); // start_time = calendar.getTime(); // calendar.set(year + 1, 1, 1, 0, 0, 0); // end_time = calendar.getTime(); // } // // return securitySupervis2Service.findFengXianFenXi(start_time, end_time, scene); } /** * 综合监管 风险分析 中间页面 * * @param * @return */ @PostMapping(value = "findFengXianFenXiTongJi", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findFengXianFenXiTongJi(Integer year, String scene) { Calendar calendar = Calendar.getInstance(); int year2 = calendar.get(Calendar.YEAR); Date start_time = null; Date end_time = null; if (year == year2) { end_time = calendar.getTime(); calendar.add(Calendar.MONTH, -11); calendar.set(calendar.get(Calendar.YEAR), calendar.get(Calendar.MONTH), 1, 0, 0, 0); calendar.set(Calendar.MILLISECOND, 0); start_time = calendar.getTime(); } else { calendar.set(year, 1, 1, 0, 0, 0); calendar.set(Calendar.MILLISECOND, 0); start_time = calendar.getTime(); calendar.set(year + 1, 1, 1, 0, 0, 0); end_time = calendar.getTime(); } return securitySupervis2Service.findFengXianFenXiTongJi(start_time, end_time, scene); } /** * 综合监管 风险分析 右边页面:风险等级统计 ,分区县统计++ * * @param * @return */ @PostMapping(value = "findFengXianFenXiTongJi2", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findFengXianFenXiTongJi2(Integer year, String scene) { return securitySupervis2Service.findFengXianFenXiTongJi2(year, scene); } /** * 综合监管 风险分析 右边页面:分析统计3 ,分月份获取各个等级的数量++ * * @param place 区县的选择 * @return */ @PostMapping(value = "findFengXianFenXiTongJi3", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findFengXianFenXiTongJi3(Integer year, String place, String scene) { return securitySupervis2Service.findFengXianFenXiTongJi3(year, place, scene); } //风险类别统计 @PostMapping(value = "findFengXianFenXiTongJiOfType", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findFengXianFenXiTongJiOfType(Integer year, String scene) { String sql = "SELECT COUNT\n" + "\t( 1 ) all_count,\n" + "\tT.fxlx \n" + "FROM\n" + "\tcitylifeline.view_risk_collect T \n" + "WHERE\n" + "\tEXTRACT ( YEAR FROM T.pgsj ) = " + year + " \n" + "\tAND T.TYPE IN ( '" + scene + "' ) \n" + "GROUP BY\n" + "\tT.fxlx \n" + "ORDER BY\n" + "\tT.fxlx"; return securitySupervis2Service.select2(sql); } /** * 综合监管 风险分析 右边页面:突分析统计4 ,分月份获取各个已处置的风险数量++ * * @param place 区县的选择 * @return */ @PostMapping(value = "findFengXianFenXiTongJi4", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object findFengXianFenXiTongJi4(Integer year, String place, String scene) { return securitySupervis2Service.findFengXianFenXiTongJi4(year, place, scene); } /** * test * * @param * @return */ @PostMapping(value = "test", produces = {"application/json;charset=UTF-8"}) @ResponseBody public Object test() { String sql = "select * from local_dict limit 6"; return securitySupervisService.select1(sql); } }