package com.ash.controller;

import com.ash.base.*;
import com.ash.entity.Case;
import com.ash.entity.CaseAnalysis;
import com.ash.entity.WarningInstance;
import com.ash.entity.WarningInstanceAnalysis;
import com.ash.enums.JFChartTypeEnum;
import com.ash.service.CaseAnalysisService;
import com.ash.service.CaseService;
import com.ash.service.WarningInstanceAnalysisService;
import com.ash.service.WarningInstanceService;
import com.ash.util.*;
import com.deepoove.poi.XWPFTemplate;
import com.deepoove.poi.config.Configure;
import com.deepoove.poi.data.PictureType;
import com.deepoove.poi.data.Pictures;
import com.deepoove.poi.data.Tables;
import com.deepoove.poi.data.style.BorderStyle;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.collections4.MapUtils;
import org.apache.commons.lang3.StringUtils;
import org.springframework.core.io.ClassPathResource;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletResponse;
import java.io.*;
import java.nio.charset.StandardCharsets;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.concurrent.atomic.AtomicReference;
import java.util.stream.Collectors;
import java.util.stream.Stream;

@RestController
@RequestMapping("/statistics")
@Slf4j
public class StatisticsController extends BaseController {

    @Resource
    private WarningInstanceService warningInstanceService;

    @Resource
    private WarningInstanceAnalysisService warningInstanceAnalysisService;

    @Resource
    private CaseAnalysisService caseAnalysisService;

    @Resource
    private CaseService caseService;

    /**
     * 各地市警情分布top7
     *
     * @param statisticsParams 参数
     * @return 数据
     */
    @RequestMapping(value = "/wiStatisticsByArea", method = RequestMethod.POST)
    public JsonResult wiStatisticsByArea(@RequestBody StatisticsParams statisticsParams) {
        try {
            List<BarChartVo> dataList = warningInstanceService.statisticsByArea(statisticsParams);
            return JsonResult.ok(OptionStatus.OPT_SUCCESS.getName(), dataList);
        } catch (Exception ex) {
            ex.printStackTrace();
            return JsonResult.error(OptionStatus.OPT_ERROR.getName());
        }
    }


    /**
     * 各地市案件分布top7
     *
     * @param statisticsParams 参数
     * @return 数据
     */
    @RequestMapping(value = "/caseStatisticsByArea", method = RequestMethod.POST)
    public JsonResult caseStatisticsByArea(@RequestBody StatisticsParams statisticsParams) {
        try {
            List<BarChartVo> dataList = caseService.statisticsByArea(statisticsParams);
            return JsonResult.ok(OptionStatus.OPT_SUCCESS.getName(), dataList);
        } catch (Exception ex) {
            ex.printStackTrace();
            return JsonResult.error(OptionStatus.OPT_ERROR.getName());
        }
    }

    /**
     * 警情趋势
     *
     * @param statisticsParams 参数
     * @return 数据
     */
    @RequestMapping(value = "/wiStatisticsByDate", method = RequestMethod.POST)
    public JsonResult wiStatisticsByDate(@RequestBody StatisticsParams statisticsParams) {
        try {
            List<BarChartVo> dataList = warningInstanceService.statisticsByDate(statisticsParams);
            return JsonResult.ok(OptionStatus.OPT_SUCCESS.getName(), dataList);
        } catch (Exception ex) {
            ex.printStackTrace();
            return JsonResult.error(OptionStatus.OPT_ERROR.getName());
        }
    }

    /**
     * 诈骗类型分布
     *
     * @param statisticsParams 参数
     * @return 数据
     */
    @RequestMapping(value = "/caseStatisticsByFraudType", method = RequestMethod.POST)
    public JsonResult caseStatisticsByFraudType(@RequestBody StatisticsParams statisticsParams) {
        try {
            List<PieChartVo> dataList = caseService.statisticsByFraudType(statisticsParams);
            return JsonResult.ok(OptionStatus.OPT_SUCCESS.getName(), dataList);
        } catch (Exception ex) {
            ex.printStackTrace();
            return JsonResult.error(OptionStatus.OPT_ERROR.getName());
        }
    }

    /**
     * 各地市top高损案件数
     *
     * @param statisticsParams 参数
     * @return 数据
     */
    @RequestMapping(value = "/caseStatisticsTotalAmountByArea", method = RequestMethod.POST)
    public JsonResult caseStatisticsTotalAmountByArea(@RequestBody StatisticsParams statisticsParams) {
        try {
            List<BarChartVo> dataList = caseService.statisticsTotalAmountByArea(statisticsParams);
            return JsonResult.ok(OptionStatus.OPT_SUCCESS.getName(), dataList);
        } catch (Exception ex) {
            ex.printStackTrace();
            return JsonResult.error(OptionStatus.OPT_ERROR.getName());
        }
    }

    /**
     * 各地市警情数量环比变化
     *
     * @param statisticsParams 参数
     * @return 数据
     */
    @RequestMapping(value = "/wiStatisticsSequentialByArea", method = RequestMethod.POST)
    public JsonResult wiStatisticsSequentialByArea(@RequestBody StatisticsParams statisticsParams) {
        try {
            statisticsParams.setStartTime(DateUtils.weeHours(statisticsParams.getStartTime(), 0));
            statisticsParams.setEndTime(DateUtils.weeHours(statisticsParams.getEndTime(), 1));
            List<BarChartVo> currentDataList = warningInstanceService.statisticsSequentialByArea(statisticsParams);
            long daysBetween = DateUtils.getDaysBetween(statisticsParams.getEndTime(), statisticsParams.getStartTime());
            StatisticsParams lp = new StatisticsParams();
            lp.setStartTime(DateUtils.getFrontDay(statisticsParams.getStartTime(), (int) daysBetween));
            lp.setEndTime(DateUtils.getFrontDay(statisticsParams.getEndTime(), (int) daysBetween));

            List<BarChartVo> lastDataList = warningInstanceService.statisticsSequentialByArea(lp);
            List<String> currentAreaList = currentDataList.stream().map(BarChartVo::getName).collect(Collectors.toList());
            List<String> lastAreaList = lastDataList.stream().map(BarChartVo::getName).collect(Collectors.toList());
            List<String> areaList = Stream.concat(currentAreaList.stream(), lastAreaList.stream())
                    .distinct()
                    .collect(Collectors.toList());
            Map<String, String> currentMap = currentDataList.stream()
                    .collect(Collectors.toMap(BarChartVo::getName, BarChartVo::getValue));
            Map<String, String> lastMap = lastDataList.stream()
                    .collect(Collectors.toMap(BarChartVo::getName, BarChartVo::getValue));

            List<PieChartVo> dataList = new ArrayList<>();
            for (String area : areaList) {
                String currentValue = currentMap.get(area);
                String lastValue = lastMap.get(area);
                int cv = StringUtils.isNotBlank(currentValue) ? Integer.parseInt(currentValue) : 0;
                int lv = StringUtils.isNotBlank(lastValue) ? Integer.parseInt(lastValue) : 0;

                String sequential = "--";
                if (lv != 0) {
                    sequential = String.format("%.1f", (cv - lv) * 1.0 / lv * 100.0);
                    PieChartVo cd = new PieChartVo(area, Double.parseDouble(sequential));
                    dataList.add(cd);
                } else {
                    //为了图表展示先用0
                    PieChartVo cd = new PieChartVo(area, 0);
                    dataList.add(cd);
                }

            }

            dataList.sort((d1, d2) -> {
                double value = ObjectValueOption.getObjDouble(d2.getValue()) - ObjectValueOption.getObjDouble(d1.getValue());
                return (int) value;
            });


            return JsonResult.ok(OptionStatus.OPT_SUCCESS.getName(), dataList);
        } catch (Exception ex) {
            ex.printStackTrace();
            return JsonResult.error(OptionStatus.OPT_ERROR.getName());
        }
    }

    /**
     * 各地市电诈案件环比变化
     *
     * @param statisticsParams 参数
     * @return 数据
     */
    @RequestMapping(value = "/caseStatisticsSequentialByArea", method = RequestMethod.POST)
    public JsonResult caseStatisticsSequentialByArea(@RequestBody StatisticsParams statisticsParams) {
        try {
            statisticsParams.setStartTime(DateUtils.weeHours(statisticsParams.getStartTime(), 0));
            statisticsParams.setEndTime(DateUtils.weeHours(statisticsParams.getEndTime(), 1));
            List<BarChartVo> currentDataList = caseService.statisticsSequentialByArea(statisticsParams);
            long daysBetween = DateUtils.getDaysBetween(statisticsParams.getEndTime(), statisticsParams.getStartTime());
            StatisticsParams lp = new StatisticsParams();
            lp.setStartTime(DateUtils.getFrontDay(statisticsParams.getStartTime(), (int) daysBetween));
            lp.setEndTime(DateUtils.getFrontDay(statisticsParams.getEndTime(), (int) daysBetween));

            List<BarChartVo> lastDataList = caseService.statisticsSequentialByArea(lp);
            List<String> currentAreaList = currentDataList.stream().map(BarChartVo::getName).collect(Collectors.toList());
            List<String> lastAreaList = lastDataList.stream().map(BarChartVo::getName).collect(Collectors.toList());
            List<String> areaList = Stream.concat(currentAreaList.stream(), lastAreaList.stream())
                    .distinct()
                    .collect(Collectors.toList());
            Map<String, String> currentMap = currentDataList.stream()
                    .collect(Collectors.toMap(BarChartVo::getName, BarChartVo::getValue));
            Map<String, String> lastMap = lastDataList.stream()
                    .collect(Collectors.toMap(BarChartVo::getName, BarChartVo::getValue));

            List<PieChartVo> dataList = new ArrayList<>();
            for (String area : areaList) {
                String currentValue = currentMap.get(area);
                String lastValue = lastMap.get(area);
                int cv = StringUtils.isNotBlank(currentValue) ? Integer.parseInt(currentValue) : 0;
                int lv = StringUtils.isNotBlank(lastValue) ? Integer.parseInt(lastValue) : 0;

                String sequential = "--";
                if (lv != 0) {
                    sequential = String.format("%.1f", (cv - lv) * 1.0 / lv * 100.0);
                    PieChartVo cd = new PieChartVo(area, Double.parseDouble(sequential));
                    dataList.add(cd);
                } else {
                    //为了图表展示先用0
                    PieChartVo cd = new PieChartVo(area, 0);
                    dataList.add(cd);
                }

            }

            dataList.sort((d1, d2) -> {
                double value = ObjectValueOption.getObjDouble(d2.getValue()) - ObjectValueOption.getObjDouble(d1.getValue());
                return (int) value;
            });


            return JsonResult.ok(OptionStatus.OPT_SUCCESS.getName(), dataList);
        } catch (Exception ex) {
            ex.printStackTrace();
            return JsonResult.error(OptionStatus.OPT_ERROR.getName());
        }
    }

    /**
     * 全省接电诈警情
     *
     * @param statisticsParams 参数
     * @return 数据
     */
    @RequestMapping(value = "/totalWiInfo", method = RequestMethod.POST)
    public JsonResult totalWiInfo(@RequestBody StatisticsParams statisticsParams) {
        try {
            statisticsParams.setStartTime(DateUtils.weeHours(statisticsParams.getStartTime(), 0));
            statisticsParams.setEndTime(DateUtils.weeHours(statisticsParams.getEndTime(), 1));
            int count = warningInstanceService.getCount(statisticsParams);
            long daysBetween = DateUtils.getDaysBetween(statisticsParams.getEndTime(), statisticsParams.getStartTime());
            StatisticsParams lp = new StatisticsParams();
            lp.setStartTime(DateUtils.getFrontDay(statisticsParams.getStartTime(), (int) daysBetween));
            lp.setEndTime(DateUtils.getFrontDay(statisticsParams.getEndTime(), (int) daysBetween));
            int lastCount = warningInstanceService.getCount(lp);
            String sequential = "--";
            if (lastCount != 0) {
                sequential = String.format("%.1f", (count - lastCount) * 1.0 / lastCount * 100.0) + "%";
            }

            Map<String, Object> result = new HashMap<>();
            result.put("value", count);
            result.put("sequential", sequential);

            return JsonResult.ok(OptionStatus.OPT_SUCCESS.getName(), result);
        } catch (Exception ex) {
            ex.printStackTrace();
            return JsonResult.error(OptionStatus.OPT_ERROR.getName());
        }
    }

    /**
     * 全省立案电诈件
     *
     * @param statisticsParams 参数
     * @return 数据
     */
    @RequestMapping(value = "/totalCaseInfo", method = RequestMethod.POST)
    public JsonResult totalCaseInfo(@RequestBody StatisticsParams statisticsParams) {
        try {
            statisticsParams.setStartTime(DateUtils.weeHours(statisticsParams.getStartTime(), 0));
            statisticsParams.setEndTime(DateUtils.weeHours(statisticsParams.getEndTime(), 1));
            int count = caseService.getCount(statisticsParams);
            long daysBetween = DateUtils.getDaysBetween(statisticsParams.getEndTime(), statisticsParams.getStartTime());
            StatisticsParams lp = new StatisticsParams();
            lp.setStartTime(DateUtils.getFrontDay(statisticsParams.getStartTime(), (int) daysBetween));
            lp.setEndTime(DateUtils.getFrontDay(statisticsParams.getEndTime(), (int) daysBetween));
            int lastCount = caseService.getCount(lp);
            String sequential = "--";
            if (lastCount != 0) {
                sequential = String.format("%.1f", (count - lastCount) * 1.0 / lastCount * 100.0) + "%";
            }

            Map<String, Object> result = new HashMap<>();
            result.put("value", count);
            result.put("sequential", sequential);

            return JsonResult.ok(OptionStatus.OPT_SUCCESS.getName(), result);
        } catch (Exception ex) {
            ex.printStackTrace();
            return JsonResult.error(OptionStatus.OPT_ERROR.getName());
        }
    }

    /**
     * 总损失
     *
     * @param statisticsParams 参数
     * @return 数据
     */
    @RequestMapping(value = "/totalLoss", method = RequestMethod.POST)
    public JsonResult totalLoss(@RequestBody StatisticsParams statisticsParams) {
        try {
            List<Case> dataList = caseService.getCaseLoss(statisticsParams);
            int caseTopLoss = caseService.getCaseTopLoss(statisticsParams);
            Double totalLoss = 0d;
            Double avgLoss = 0d;
            if (CollectionUtils.isNotEmpty(dataList)) {
                for (Case caseInfo : dataList) {
                    if (caseInfo.getTotalAmount() == null) {
                        continue;
                    }
                    totalLoss += caseInfo.getTotalAmount();
                }
                avgLoss = totalLoss * 1.0 / dataList.size();
            }


            Map<String, Object> result = new HashMap<>();
            result.put("totalLoss", String.format("%.1f", totalLoss));
            result.put("avgLoss", String.format("%.1f", avgLoss));
            result.put("caseValue", caseTopLoss);

            return JsonResult.ok(OptionStatus.OPT_SUCCESS.getName(), result);
        } catch (Exception ex) {
            ex.printStackTrace();
            return JsonResult.error(OptionStatus.OPT_ERROR.getName());
        }
    }

    @PostMapping("/majorCasePage")
    public JsonResult majorCasePage(@RequestBody StatisticsParams statisticsParams) {
        statisticsParams.setStartTime(DateUtils.weeHours(statisticsParams.getStartTime(), 0));
        statisticsParams.setEndTime(DateUtils.weeHours(statisticsParams.getEndTime(), 1));

        List<Case> dataList = caseService.majorCasePage(statisticsParams);
        if (CollectionUtils.isNotEmpty(dataList)) {
            List<String> caseIds = dataList
                    .stream().map(Case::getId).collect(Collectors.toList());
            Map<String, CaseAnalysis> caseAnalysisMap = caseAnalysisService.listByCaseId(caseIds);
            dataList.forEach(e -> e.setAnalysis(caseAnalysisMap.get(e.getId())));
        }
        return JsonResult.ok(OptionStatus.OPT_SUCCESS.getName(), dataList);

    }


    @GetMapping("/downloadReport")
    public void downloadReport(@RequestParam(value = "startTime", required = true) String startTime,
                               @RequestParam(value = "endTime", required = true) String endTime,
                               HttpServletResponse response) throws ParseException, IOException {
        Map<String, Object> dataMap = new HashMap<>();
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
        StatisticsParams statisticsParams = new StatisticsParams();
        statisticsParams.setStartTime(DateUtils.weeHours(sdf.parse(startTime), 0));
        statisticsParams.setEndTime(DateUtils.weeHours(sdf.parse(endTime), 1));
        JsonResult totalWiInfo = totalWiInfo(statisticsParams);
        dataMap.put("totalInfo", totalWiInfo.getData());

        JsonResult totalCaseInfo = totalCaseInfo(statisticsParams);
        dataMap.put("totalCaseInfo", totalCaseInfo.getData());

        //警情各地市分布饼图
        List<PieChartVo> wiAreaData = warningInstanceService.statisticsCountByArea(statisticsParams);
        dataMap.put("wiAreaData", wiAreaData);

        //警情各地市环比变化柱状图
        JsonResult wissAreaData = wiStatisticsSequentialByArea(statisticsParams);
        dataMap.put("wissAreaData", wissAreaData.getData());

        //警情子类分布
        List<PieChartVo> wiSubTypeData = warningInstanceService.statisticsCountBySubType(statisticsParams);
        dataMap.put("wiSubTypeData", wiSubTypeData);

        //警情趋势
        List<BarChartVo> wisDateData = warningInstanceService.statisticsByDate(statisticsParams);
        List<PieChartVo> pdWisDateData = wisDateData.stream()
                .map(e -> new PieChartVo(e.getName(), e.getValue())).collect(Collectors.toList());
        dataMap.put("wisDateData", pdWisDateData);

        //案件各地市分布
        List<PieChartVo> caseAreaData = caseService.statisticsCountByArea(statisticsParams);
        dataMap.put("caseAreaData", caseAreaData);

        //电诈案件环比情况
        JsonResult caseSsAreaData = caseStatisticsSequentialByArea(statisticsParams);
        dataMap.put("caseSsAreaData", caseSsAreaData.getData());

        //案件诈骗类型分布
        JsonResult csfData = caseStatisticsByFraudType(statisticsParams);
        dataMap.put("csfData", csfData.getData());

        //案件引流方式分布图
        List<PieChartVo> ccrmData = caseService.statisticsCountByRainageMethod(statisticsParams);
        dataMap.put("ccrmData", ccrmData);

        //案件支付方式分布图
        List<PieChartVo> ccpmData = caseService.statisticsCountByPayMethod(statisticsParams);
        dataMap.put("ccpmData", ccpmData);

        //案件受害人职业分布图
        List<PieChartVo> ccCareerData = caseService.statisticsCountByCareer(statisticsParams);
        dataMap.put("ccCareerData", ccCareerData);

        //案损分布
        List<PieChartVo> ccLossData = caseService.statisticsByLoss(statisticsParams);
        dataMap.put("ccLossData", ccLossData);

        //发案趋势
        List<PieChartVo> ccDateData = caseService.statisticsByDate(statisticsParams);
        dataMap.put("ccDateData", ccDateData);

        //案件受害人性别占比
        List<PieChartVo> sexData = caseService.statisticsCountBySex(statisticsParams);
        dataMap.put("sexData", sexData);

        //案件受害人年龄占比
        List<PieChartVo> ageData = caseService.statisticsByAge(statisticsParams);
        dataMap.put("ageData", ageData);

        //50w以上案件
        JsonResult majorCaseData = majorCasePage(statisticsParams);
        dataMap.put("majorCaseData", majorCaseData.getData());

        //50w以上警情
        List<WarningInstance> majorWiData = warningInstanceService.majorWiPage(statisticsParams);
        if (CollectionUtils.isNotEmpty(majorWiData)) {
            List<String> wiIds = majorWiData
                    .stream().map(WarningInstance::getId).collect(Collectors.toList());
            Map<String, WarningInstanceAnalysis> analysisMap = warningInstanceAnalysisService.listByWiId(wiIds);
            majorWiData.forEach(e -> e.setAnalysis(analysisMap.get(e.getId())));
        }
        dataMap.put("majorWiData", majorWiData);

        // 生成最终文件路径
        String fileName = UUIDGenerator.uuid() + ".docx";
        String filePath = JFChartUtils.OUTPUT_DIR + fileName;

        String dataRange = "【" + (startTime.equals(endTime) ? startTime : startTime + "~" + endTime) + "】";

        buildWord(dataMap, dataRange, filePath);
        try {
            response.setContentType("application/octet-stream");
            response.setCharacterEncoding("utf-8");
            String downloadName = "统计报表";
            downloadName = new String(downloadName.getBytes(StandardCharsets.UTF_8), StandardCharsets.ISO_8859_1);
            response.setHeader("Content-Disposition", "attachment;filename=" + downloadName + ".docx");

            InputStream inputStream = new FileInputStream(filePath);
            OutputStream outputStream = response.getOutputStream();
            byte[] buffer = new byte[4096];
            int bytesRead = -1;
            while ((bytesRead = inputStream.read(buffer)) != -1) {
                outputStream.write(buffer, 0, bytesRead);
            }
            inputStream.close();
            outputStream.close();
        } catch (Exception e) {
            e.printStackTrace();
        }

    }

    @SuppressWarnings("unchecked")
    public void buildWord(Map<String, Object> data, String dataRange, String filePath) throws IOException {

        ClassPathResource resource = new ClassPathResource("/template/statisticsReport.docx");
        File file = new File(resource.getFile().toPath().toString());

        Map<String, Object> dataMap = new HashMap<>();

        Map<String, Object> totalInfo = (Map<String, Object>) data.get("totalInfo");
        // 警情总体情况
        dataMap.put("date", dataRange);
        dataMap.put("wiValue", totalInfo.get("value"));

        String sequential = (String) totalInfo.get("sequential");
        if ("--".equals(sequential)) {
            dataMap.put("ns", true);
        } else {
            dataMap.put("hs", true);
            dataMap.put("sequential", sequential.replaceAll("-", ""));
            dataMap.put("sequentialType", sequential.contains("-") ? "下降" : "上升");
        }

        //案件总体情况
        Map<String, Object> totalCaseInfo = (Map<String, Object>) data.get("totalCaseInfo");
        dataMap.put("caseValue", totalCaseInfo.get("value"));
        String caseSequential = (String) totalCaseInfo.get("sequential");
        if ("--".equals(caseSequential)) {
            dataMap.put("cns", true);
        } else {
            dataMap.put("chs", true);
            dataMap.put("caseSequential", caseSequential.replaceAll("-", ""));
            dataMap.put("caseSequentialType", caseSequential.contains("-") ? "下降" : "上升");
        }

        //警情各地市分布饼图
        List<PieChartVo> wiAreaDataList = (List<PieChartVo>) data.get("wiAreaData");
        String dailyPicFile = JFChartUtils.createChart(wiAreaDataList, JFChartTypeEnum.PIE, dataRange + "警情分布图", "市", "数量");
        dataMap.put("sWIAreaPic", Pictures.ofStream(new FileInputStream(dailyPicFile), PictureType.JPEG).size(600, 200).create());

        //警情各地市环比变化柱状图
        List<PieChartVo> wissAreaData = (List<PieChartVo>) data.get("wissAreaData");
        String sWISeqAreaPic = JFChartUtils.createChart(wissAreaData, JFChartTypeEnum.BAR, dataRange + "警情环比情况", "市", "环比");
        dataMap.put("sWISeqAreaPic", Pictures.ofStream(new FileInputStream(sWISeqAreaPic), PictureType.JPEG).size(600, 200).create());

        //警情子类分布
        List<PieChartVo> wiSubTypeData = (List<PieChartVo>) data.get("wiSubTypeData");
        String wiSubTypeDataPic = JFChartUtils.createChart(wiSubTypeData, JFChartTypeEnum.PIE, dataRange + "警情类别分布", "警情类别", "数量");
        dataMap.put("wiSubTypeDataPic", Pictures.ofStream(new FileInputStream(wiSubTypeDataPic), PictureType.JPEG).size(600, 200).create());


        //警情分析
        List<PieChartVo> wisDateData = (List<PieChartVo>) data.get("wisDateData");
        String wisDateDataPic = JFChartUtils.createChart(wisDateData, JFChartTypeEnum.LINE, dataRange + "警情趋势", "市", "数量");
        dataMap.put("wisDateDataPic", Pictures.ofStream(new FileInputStream(wisDateDataPic), PictureType.JPEG).size(600, 200).create());

        //案件各地市分布
        List<PieChartVo> caseAreaData = (List<PieChartVo>) data.get("caseAreaData");
        String caseAreaDataPic = JFChartUtils.createChart(caseAreaData, JFChartTypeEnum.PIE, dataRange + "案件分布图", "市", "数量");
        dataMap.put("caseAreaDataPic", Pictures.ofStream(new FileInputStream(caseAreaDataPic), PictureType.JPEG).size(600, 200).create());

        //电诈案件环比情况
        List<PieChartVo> caseSsAreaData = (List<PieChartVo>) data.get("caseSsAreaData");
        String caseSsAreaDataPic = JFChartUtils.createChart(caseSsAreaData, JFChartTypeEnum.BAR, dataRange + "电诈案件环比情况", "市", "环比");
        dataMap.put("caseSsAreaDataPic", Pictures.ofStream(new FileInputStream(caseSsAreaDataPic), PictureType.JPEG).size(600, 200).create());

        //案件诈骗类型分布
        List<PieChartVo> csfData = (List<PieChartVo>) data.get("csfData");
        String sCsfDataPic = JFChartUtils.createChart(csfData, JFChartTypeEnum.PIE, dataRange + "诈骗类型分布", "诈骗类型", "数量");
        dataMap.put("sCsfDataaPic", Pictures.ofStream(new FileInputStream(sCsfDataPic), PictureType.JPEG).size(600, 200).create());

        //案件引流方式分布图
        List<PieChartVo> ccrmData = (List<PieChartVo>) data.get("ccrmData");
        String ccrmDataPic = JFChartUtils.createChart(ccrmData, JFChartTypeEnum.PIE, dataRange + "引流方式分布图", "引流方式", "数量");
        dataMap.put("ccrmDataPic", Pictures.ofStream(new FileInputStream(ccrmDataPic), PictureType.JPEG).size(600, 200).create());

        //案件支付方式分布图
        List<PieChartVo> ccpmData = (List<PieChartVo>) data.get("ccpmData");
        String ccpmDataPic = JFChartUtils.createChart(ccpmData, JFChartTypeEnum.PIE, dataRange + "支付方式分布图", "支付方式", "数量");
        dataMap.put("ccpmDataPic", Pictures.ofStream(new FileInputStream(ccpmDataPic), PictureType.JPEG).size(600, 200).create());

        //案件受害人职业分布图
        List<PieChartVo> ccCareerData = (List<PieChartVo>) data.get("ccCareerData");
        String ccCareerDataPic = JFChartUtils.createChart(ccCareerData, JFChartTypeEnum.BAR, dataRange + "受害人职业分布图", "受害人职业", "数量");
        dataMap.put("ccCareerDataPic", Pictures.ofStream(new FileInputStream(ccCareerDataPic), PictureType.JPEG).size(600, 200).create());

        //案损分布
        List<PieChartVo> ccLossData = (List<PieChartVo>) data.get("ccLossData");
        String ccLossDataPic = JFChartUtils.createChart(ccLossData, JFChartTypeEnum.BAR, dataRange + "案损分布", "案损", "数量");
        dataMap.put("ccLossDataPic", Pictures.ofStream(new FileInputStream(ccLossDataPic), PictureType.JPEG).size(600, 200).create());

        int clIndex = 1;
        for (PieChartVo clData : ccLossData) {
            String key = "clr" + clIndex++;
            dataMap.put(key, clData.getValue());
        }

        //发案趋势
        List<PieChartVo> ccDateData = (List<PieChartVo>) data.get("ccDateData");
        String ccDateDataPic = JFChartUtils.createChart(ccDateData, JFChartTypeEnum.LINE, dataRange + "发案趋势", "日期", "数量");
        dataMap.put("ccDateDataPic", Pictures.ofStream(new FileInputStream(ccDateDataPic), PictureType.JPEG).size(600, 200).create());


        //案件受害人性别占比
        List<PieChartVo> sexData = (List<PieChartVo>) data.get("sexData");
        if (CollectionUtils.isNotEmpty(sexData)) {
            AtomicReference<Integer> st = new AtomicReference<>(0);
            sexData.forEach(e -> st.updateAndGet(v -> v + (Integer) e.getValue()));
            for (PieChartVo cd : sexData) {
                if ("男".equals(cd.getName())) {
                    dataMap.put("cMValue", cd.getValue());
                    dataMap.put("cMValuePer", String.format("%.1f", (Integer) cd.getValue() * 100.0 / st.get()) + "%");
                } else if ("女".equals(cd.getName())) {
                    dataMap.put("cFValue", cd.getValue());
                    dataMap.put("cFValuePer", String.format("%.1f", (Integer) cd.getValue() * 100.0 / st.get()) + "%");

                }
            }
        }

        //案件受害人年龄占比
        List<PieChartVo> ageData = (List<PieChartVo>) data.get("ageData");
        if (CollectionUtils.isNotEmpty(ageData)) {
            AtomicReference<Integer> at = new AtomicReference<>(0);
            ageData.forEach(e -> at.updateAndGet(v -> v + (Integer) e.getValue()));
            for (PieChartVo cd : ageData) {
                dataMap.put(cd.getName(), cd.getValue());
                dataMap.put(cd.getName() + "Per", String.format("%.1f", (Integer) cd.getValue() * 100.0 / at.get()) + "%");
            }
        }

        //案损列表
        List<Case> majorCaseData = (List<Case>) data.get("majorCaseData");
        List<CaseLossVo> nllDataList = new ArrayList<>();
        CaseLossVo header = new CaseLossVo();
        header.setCode("案件编号");
        header.setArea("地区");
        header.setCounty("县区");
        header.setTotalAmount("案损");
        header.setFraudType("诈骗类型");
        header.setRainageMethod("引流方式");
        header.setPayMethod("资金支持途径");
        header.setSex("受害人性别");
        header.setCareer("受害人职业");
        nllDataList.add(header);

        String caseLossAreas = "";
        Map<String, String> caseLossAreaMap = new HashMap<>();
        if (CollectionUtils.isNotEmpty(majorCaseData)) {
            for (Case cd : majorCaseData) {
                CaseLossVo clv = new CaseLossVo();
                clv.setCode(cd.getCode());
                clv.setArea(cd.getAnalysis().getArea());
                clv.setCounty(cd.getAnalysis().getCounty());
                clv.setTotalAmount(String.valueOf(cd.getAnalysis().getTotalAmount()));
                clv.setFraudType(cd.getAnalysis().getFraudType());
                clv.setRainageMethod(cd.getAnalysis().getRainageMethod());
                clv.setPayMethod(cd.getAnalysis().getPayMethod());
                clv.setSex(cd.getAnalysis().getSex());
                clv.setCareer(cd.getAnalysis().getCareer());
                nllDataList.add(clv);
                caseLossAreaMap.put(cd.getAnalysis().getArea(), "");
            }
        }


        String[][] majorCaseDataArray = nllDataList.stream()
                .map(e -> new String[]{e.getArea(), e.getCounty(), e.getCode()
                        , e.getTotalAmount(), e.getFraudType(), e.getRainageMethod()
                        , e.getPayMethod(), e.getSex(), e.getCareer()
                }).toArray(String[][]::new);
        dataMap.put("tableMcd", Tables.of(majorCaseDataArray).border(BorderStyle.DEFAULT).create());

        //警情损失列表
        List<WarningInstance> majorWiData = (List<WarningInstance>) data.get("majorWiData");
        List<WiLossVo> mwiDataList = new ArrayList<>();
        WiLossVo wiHeader = new WiLossVo();
        wiHeader.setCode("案件编号");
        wiHeader.setArea("地区");
        wiHeader.setCounty("县区");
        wiHeader.setAlarmSubType("案件类别");
        wiHeader.setAmount("案损");
        wiHeader.setRainageMethod("引流方式");
        wiHeader.setPayMethod("支付渠道");
        wiHeader.setSex("受害人性别");
        wiHeader.setCareer("受害人职业");
        mwiDataList.add(wiHeader);

        Integer wi50wValue = 0;
        Integer wi100wValue = 0;
        if (CollectionUtils.isNotEmpty(majorWiData)) {
            for (WarningInstance cd : majorWiData) {
                WiLossVo clv = new WiLossVo();
                clv.setCode(cd.getCode());
                clv.setArea(cd.getAnalysis().getArea());
                clv.setCounty(cd.getAnalysis().getCounty());
                clv.setAlarmSubType(cd.getAlarmSubType());
                clv.setAmount(String.valueOf(cd.getAnalysis().getAmount()));
                clv.setRainageMethod(cd.getAnalysis().getRainageMethod());
                clv.setPayMethod(cd.getAnalysis().getPayMethod());
                clv.setSex(cd.getAnalysis().getSex());
                clv.setCareer(cd.getAnalysis().getCareer());
                mwiDataList.add(clv);
                caseLossAreaMap.put(cd.getAnalysis().getArea(), "");
                if (cd.getAnalysis().getAmount() < 1000000) {
                    wi50wValue++;
                } else {
                    wi100wValue++;
                }
            }
        }

        dataMap.put("wi50wValue", wi50wValue);
        dataMap.put("wi100wValue", wi100wValue);

        String[][] majorWiDataArray = mwiDataList.stream()
                .map(e -> new String[]{e.getCode(), e.getArea(), e.getCounty()
                        , e.getAlarmSubType(), e.getAmount(), e.getRainageMethod()
                        , e.getPayMethod(), e.getSex(), e.getCareer()
                }).toArray(String[][]::new);
        dataMap.put("tableMwd", Tables.of(majorWiDataArray).border(BorderStyle.DEFAULT).create());

        if (MapUtils.isNotEmpty(caseLossAreaMap)) {
            caseLossAreas = String.join(",", caseLossAreaMap.keySet());
        }

        caseLossAreas = StringUtils.isNotBlank(caseLossAreas) ? caseLossAreas : "--";
        dataMap.put("caseLossAreas", caseLossAreas);


        try (XWPFTemplate template = XWPFTemplate.compile(file, Configure.newBuilder().buildGramer("${", "}").build())
                .render(dataMap)) {
            template.writeToFile(filePath);
        }

    }

}