programs_info/无锡市生命线项目/数据库备份/删除前备份/代码修改前备份/前置数据库中的视图都移动到后管平台进行的修改/SecuritySuperviseController.java

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<String, Object> info) {
        return securitySupervis2Service.findRiskCountList(info);
    }

    /**
     * 风险超过24小时的数量查询
     *
     * @param info
     * @return
     */
    @PostMapping(value = "findOverHourRiskCountList", produces = {"application/json;charset=UTF-8"})
    @ResponseBody
    public Object findOverHourRiskCountList(Map<String, Object> info) {
        return securitySupervis2Service.findOverHourRiskCountList(info);
    }

    /**
     * 隐患数量列表查询
     *
     * @param info
     * @return
     */
    @PostMapping(value = "findTroubleCountList", produces = {"application/json;charset=UTF-8"})
    @ResponseBody
    public Object findTroubleCountList(Map<String, Object> info) {
        return securitySupervisService.findTroubleCountList(info);
    }

    /**
     * 隐患超过24小时的数量查询
     *
     * @param info
     * @return
     */
    @PostMapping(value = "findOverHourTroubleCountList", produces = {"application/json;charset=UTF-8"})
    @ResponseBody
    public Object findOverHourTroubleCountList(Map<String, Object> info) {
        return securitySupervisService.findOverHourTroubleCountList(info);
    }

    /**
     * 突发事件数量列表查询
     *
     * @param info
     * @return
     */
    @PostMapping(value = "findEmergencyCountList", produces = {"application/json;charset=UTF-8"})
    @ResponseBody
    public Object findEmergencyCountList(Map<String, Object> info) {
        return securitySupervisService.findEmergencyCountList(info);
    }

    /**
     * 突发事件超过24小时的数量查询
     *
     * @param info
     * @return
     */
    @PostMapping(value = "findOverHourEmergencyCountList", produces = {"application/json;charset=UTF-8"})
    @ResponseBody
    public Object findOverHourEmergencyCountList(Map<String, Object> 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<String> 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)) &lt;= (24*60*60)");
                    }
                }
                info.setIsTimeoutList(strings);
            }
//            return securitySupervis2Service.findInfoRiskDetailEveryPlace(info);
            PageInfo<Map<String, Object>> page = securitySupervis2Service.findInfoRiskDetailEveryPlace(tablepar, info);
            TableSplitResult<Map<String, Object>> 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<String> 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)) &lt;= (24*60*60)");
                    }
                }
                info.setIsTimeoutList(strings);
            }
//            return securitySupervisService.findInfoTroubleDetailEveryPlace(info);
            PageInfo<Map<String, Object>> page = securitySupervisService.findInfoTroubleDetailEveryPlace(tablepar, info);
            TableSplitResult<Map<String, Object>> 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<String> 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)) &lt;= (24*60*60)");
                    }
                }
                info.setIsTimeoutList(strings);
            }
//            return securitySupervisService.findInfoEmergencyDetailEveryPlace(info);
            PageInfo<Map<String, Object>> page = securitySupervisService.findInfoEmergencyDetailEveryPlace(tablepar, info);
            TableSplitResult<Map<String, Object>> 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<Map<String, Object>> page = securitySupervisService.findShiJianFenXi(tablepar, info);
        TableSplitResult<Map<String, Object>> 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<Map<String, Object>> page = securitySupervisService.findYinHuanFenXi(tablepar, info);
//        TableSplitResult<Map<String, Object>> 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<Map<String, Object>> 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<Map<String, Object>> page = securitySupervisService.findYinHuanFenXiOther(tablepar, info);
        TableSplitResult<Map<String, Object>> 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 ,分月份获取各个已处置的事件数量_第三方++
     * <p>
     * 没有完成的数据
     *
     * @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<Map<String, Object>> page = securitySupervisService.findFengXianHistoryList(tablepar, info);

        TableSplitResult<Map<String, Object>> 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);

    }
}