package cn.besteam.modules.report.biz;

import cn.besteam.common.constant.DepartmentEnum;
import cn.besteam.common.constant.ErrorCode;
import cn.besteam.common.constant.MedicalWasteEnum;
import cn.besteam.common.exception.BusinessException;
import cn.besteam.common.util.DateUtil;
import cn.besteam.modules.medical.entity.MwCollectRecord;
import cn.besteam.modules.medical.entity.MwCollectRecordDaySummary;
import cn.besteam.modules.medical.entity.MwCollectionAmendantRecord;
import cn.besteam.modules.medical.entity.MwWarningRecord;
import cn.besteam.modules.medical.service.*;
import cn.besteam.modules.report.dto.CollectRecordSummaryDTO;
import cn.besteam.modules.report.dto.CollectionWarningLevelDTO;
import cn.besteam.modules.report.dto.MedicalReportDTO;
import cn.besteam.modules.report.dto.ReportCollectionAmendantDTO;
import cn.besteam.modules.report.vo.*;
import cn.besteam.modules.system.entity.SysDepartment;
import cn.besteam.modules.system.entity.SysDepartmentInformation;
import cn.besteam.modules.system.entity.SysDictItem;
import cn.besteam.modules.system.service.ISysDepartmentInformationService;
import cn.besteam.modules.system.service.ISysDepartmentService;
import cn.besteam.modules.system.service.ISysDictItemService;
import cn.besteam.modules.system.vo.SysDepartmentInformationReportVO;
import cn.hutool.poi.excel.ExcelWriter;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections.CollectionUtils;
import org.apache.poi.ss.usermodel.HorizontalAlignment;
import org.apache.poi.ss.usermodel.VerticalAlignment;
import org.apache.poi.ss.util.CellRangeAddress;
import org.apache.poi.xssf.usermodel.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.math.BigDecimal;
import java.net.URLEncoder;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.stream.Collectors;
import java.util.stream.Stream;

import static cn.besteam.common.util.DateUtil.*;

/**
 * 监管统计
 */
@Service
@Slf4j
public class RegulatoryStatisticalBiz {

    @Autowired
    private ISysDepartmentService sysDepartmentService;

    @Autowired
    private IMwCollectRecordService mwCollectRecordService;

    @Autowired
    private ISysDepartmentInformationService sysDepartmentInformationService;

    @Autowired
    private IMwCollectionAmendantRecordService mwCollectionAmendantRecordService;

    @Autowired
    private IMwWarningRecordService warningRecordService;

    /**
     * 区域产废修改报表
     *
     * @param dto
     * @return
     */
    public DepartmentCollectionAmendantReportVO getCollectionAmendantRecordReportList(ReportCollectionAmendantDTO dto) {

        SysDepartment department = sysDepartmentService.getById(dto.getDepartmentId());
        if (department == null) {
            throw new BusinessException(ErrorCode.ERR_500, "区域不存在");
        }
        /*if(dto.getStyleTpl()==1){
            if (!department.getOrgType().equals(DepartmentEnum.OrgTypeEnum.AREA.getType())) {
                throw new BusinessException(ErrorCode.ERR_500, "区域不存在");
            }
        }else if(dto.getStyleTpl()==2){
            if (!department.getOrgType().equals(DepartmentEnum.OrgTypeEnum.HOSPITAL.getType())) {
                throw new BusinessException(ErrorCode.ERR_500, "医院不存在");
            }
        }*/

        DepartmentCollectionAmendantReportVO vo = new DepartmentCollectionAmendantReportVO();
        vo.setDepartmentName(department.getDepartName());
       /* List<SysDictItem> wasteTypeList = getWasteTypeList();
        if (CollectionUtils.isEmpty(wasteTypeList)) {
            return vo;
        }
        vo.setLegend(wasteTypeList.stream().map(SysDictItem::getItemText).collect(Collectors.toList()));
        vo.getLegend().add("小计");*/
        //

        List<SysDepartmentInformation> sysDepartmentInformationList = new ArrayList<>();
        if(dto.getDepartmentLevel()!=null || dto.getDepartmentProperty()!=null || dto.getDepartmentType()!=null || dto.getIsCourts()!=null){
            QueryWrapper<SysDepartmentInformation> wrapper = new QueryWrapper<SysDepartmentInformation>();
            wrapper.lambda();
            if(dto.getDepartmentLevel()!=null) wrapper.eq("department_level",dto.getDepartmentLevel());
            if(dto.getDepartmentProperty()!=null) wrapper.eq("department_property",dto.getDepartmentProperty());
            if(dto.getDepartmentType()!=null) wrapper.eq("department_type",dto.getDepartmentType());
            if(dto.getIsCourts()!=null) wrapper.eq("is_courts",dto.getIsCourts());
            sysDepartmentInformationList = sysDepartmentInformationService.list(wrapper);
        }
        List<MwCollectRecord> totalMwCollectRecordList = new ArrayList<>();
        List<DepartmentReportItemVO> voList = new ArrayList<>();
        Integer num1=0;Integer num2=0;Integer num3=0;Integer num4=0;Integer num5=0;Integer num6=0;
        if(dto.getStatisticalWayType()==1){//区域统计
            List<SysDepartment> regionList = sysDepartmentService.list(new QueryWrapper<SysDepartment>()//
                    .lambda()//
                    .eq(SysDepartment::getParentId, department.getId())//
                    //.likeRight(SysDepartment::getTreeCode, department.getTreeCode())//
                    .eq(SysDepartment::getOrgType, DepartmentEnum.OrgTypeEnum.AREA.getType()));//
            if (CollectionUtils.isEmpty(regionList)) {
                return vo;
            }
            for (SysDepartment sysDepartment : regionList) {
                Integer subtotal=0;
                DepartmentReportItemVO itemVO = new DepartmentReportItemVO();
                itemVO.setKey(sysDepartment.getId());
                itemVO.setName(sysDepartment.getDepartName());
                itemVO.setData(new ArrayList<>());
                //获取下级组织
                List<SysDepartment> childrenList = sysDepartmentService.list(new QueryWrapper<SysDepartment>().lambda().likeRight(SysDepartment::getTreeCode, sysDepartment.getTreeCode()));
                if (CollectionUtils.isNotEmpty(childrenList)) {
                    if(CollectionUtils.isNotEmpty(sysDepartmentInformationList)){
                        Integer numTotal = mwCollectRecordService.count(new QueryWrapper<MwCollectRecord>().lambda()//
                                .between(MwCollectRecord::getCreateTime, DateUtil.format(dto.getStartTime(), "yyyy-MM-dd HH:mm:ss"), DateUtil.format(dto.getEndTime(), "yyyy-MM-dd HH:mm:ss"))//
                                .in(MwCollectRecord::getHospitalId, childrenList.stream().map(SysDepartment::getId).collect(Collectors.toList()))//
                                .in(MwCollectRecord::getHospitalId, sysDepartmentInformationList.stream().map(SysDepartmentInformation::getDepartmentId).collect(Collectors.toList()))//
                                .eq(MwCollectRecord::getDelFlag, 0)//
                                .eq(MwCollectRecord::getAuditStatus, MedicalWasteEnum.MedicalWasteAuditStatusEnum.PASS.getStatus()));
                        itemVO.getData().add(new BigDecimal(numTotal));
                        num1+=numTotal;
                        Integer num = mwCollectRecordService.count(new QueryWrapper<MwCollectRecord>().lambda()//
                                .between(MwCollectRecord::getCreateTime, DateUtil.format(dto.getStartTime(), "yyyy-MM-dd HH:mm:ss"), DateUtil.format(dto.getEndTime(), "yyyy-MM-dd HH:mm:ss"))//
                                .in(MwCollectRecord::getHospitalId, childrenList.stream().map(SysDepartment::getId).collect(Collectors.toList()))//
                                .in(MwCollectRecord::getHospitalId, sysDepartmentInformationList.stream().map(SysDepartmentInformation::getDepartmentId).collect(Collectors.toList()))//
                                .eq(MwCollectRecord::getDelFlag, 0)//
                                .eq(MwCollectRecord::getAuditStatus, MedicalWasteEnum.MedicalWasteAuditStatusEnum.PASS.getStatus())
                                .eq(MwCollectRecord::getSource, 2));
                        itemVO.getData().add(new BigDecimal(num));
                        if(numTotal>0){
                            itemVO.getData().add(new BigDecimal(num).divide(new BigDecimal(numTotal)).multiply(BigDecimal.valueOf(100)).setScale(2,BigDecimal.ROUND_UP));
                        }else{
                            itemVO.getData().add(new BigDecimal(0));
                        }
                        num2+=num;
                        num6+=num;subtotal+=num;
                        num =  mwCollectionAmendantRecordService.count(new QueryWrapper<MwCollectionAmendantRecord>().lambda()//
                                .between(MwCollectionAmendantRecord::getCreateTime, DateUtil.format(dto.getStartTime(), "yyyy-MM-dd HH:mm:ss"), DateUtil.format(dto.getEndTime(), "yyyy-MM-dd HH:mm:ss"))//
                                .in(MwCollectionAmendantRecord::getHospitalId, childrenList.stream().map(SysDepartment::getId).collect(Collectors.toList()))//
                                .in(MwCollectionAmendantRecord::getHospitalId, sysDepartmentInformationList.stream().map(SysDepartmentInformation::getDepartmentId).collect(Collectors.toList()))//
                                .eq(MwCollectionAmendantRecord::getDelFlag, 0)//);
                                .eq(MwCollectionAmendantRecord::getType, 1));
                        itemVO.getData().add(new BigDecimal(num));
                        if(numTotal>0){
                            itemVO.getData().add(new BigDecimal(num).divide(new BigDecimal(numTotal),4,BigDecimal.ROUND_UP).multiply(BigDecimal.valueOf(100)).setScale(2,BigDecimal.ROUND_UP));
                        }else{
                            itemVO.getData().add(new BigDecimal(0));
                        }
                        num3+=num;
                        num6+=num;subtotal+=num;
                        num =  mwCollectionAmendantRecordService.count(new QueryWrapper<MwCollectionAmendantRecord>().lambda()//
                                .between(MwCollectionAmendantRecord::getCreateTime, DateUtil.format(dto.getStartTime(), "yyyy-MM-dd HH:mm:ss"), DateUtil.format(dto.getEndTime(), "yyyy-MM-dd HH:mm:ss"))//
                                .in(MwCollectionAmendantRecord::getHospitalId, childrenList.stream().map(SysDepartment::getId).collect(Collectors.toList()))//
                                .in(MwCollectionAmendantRecord::getHospitalId, sysDepartmentInformationList.stream().map(SysDepartmentInformation::getDepartmentId).collect(Collectors.toList()))//
                                .eq(MwCollectionAmendantRecord::getDelFlag, 0)//);
                                .eq(MwCollectionAmendantRecord::getType, 2));
                        itemVO.getData().add(new BigDecimal(num));
                        if(numTotal>0){
                            itemVO.getData().add(new BigDecimal(num).divide(new BigDecimal(numTotal),4,BigDecimal.ROUND_UP).multiply(BigDecimal.valueOf(100)).setScale(2,BigDecimal.ROUND_UP));
                        }else{
                            itemVO.getData().add(new BigDecimal(0));
                        }
                        num4+=num;
                        num6+=num;subtotal+=num;
                        num =  mwCollectionAmendantRecordService.count(new QueryWrapper<MwCollectionAmendantRecord>().lambda()//
                                .between(MwCollectionAmendantRecord::getCreateTime, DateUtil.format(dto.getStartTime(), "yyyy-MM-dd HH:mm:ss"), DateUtil.format(dto.getEndTime(), "yyyy-MM-dd HH:mm:ss"))//
                                .in(MwCollectionAmendantRecord::getHospitalId, childrenList.stream().map(SysDepartment::getId).collect(Collectors.toList()))//
                                .in(MwCollectionAmendantRecord::getHospitalId, sysDepartmentInformationList.stream().map(SysDepartmentInformation::getDepartmentId).collect(Collectors.toList()))//
                                .eq(MwCollectionAmendantRecord::getDelFlag, 0)//);
                                .eq(MwCollectionAmendantRecord::getType, 3));
                        itemVO.getData().add(new BigDecimal(num));
                        if(numTotal>0){
                            itemVO.getData().add(new BigDecimal(num).divide(new BigDecimal(numTotal),4,BigDecimal.ROUND_UP).multiply(BigDecimal.valueOf(100)).setScale(2,BigDecimal.ROUND_UP));
                        }else{
                            itemVO.getData().add(new BigDecimal(0));
                        }
                        num5+=num;
                        num6+=num;subtotal+=num;

                        itemVO.getData().add(new BigDecimal(subtotal));
                        if(numTotal>0){
                            itemVO.getData().add(new BigDecimal(subtotal).divide(new BigDecimal(numTotal),4,BigDecimal.ROUND_UP).multiply(BigDecimal.valueOf(100)).setScale(2,BigDecimal.ROUND_UP));
                        }else{
                            itemVO.getData().add(new BigDecimal(0));
                        }
                    }else{
                        Integer numTotal = mwCollectRecordService.count(new QueryWrapper<MwCollectRecord>().lambda()//
                                .between(MwCollectRecord::getCreateTime, DateUtil.format(dto.getStartTime(), "yyyy-MM-dd HH:mm:ss"), DateUtil.format(dto.getEndTime(), "yyyy-MM-dd HH:mm:ss"))//
                                .in(MwCollectRecord::getHospitalId, childrenList.stream().map(SysDepartment::getId).collect(Collectors.toList()))//
                                .eq(MwCollectRecord::getDelFlag, 0)//
                                .eq(MwCollectRecord::getAuditStatus, MedicalWasteEnum.MedicalWasteAuditStatusEnum.PASS.getStatus()));
                        itemVO.getData().add(new BigDecimal(numTotal));
                        num1+=numTotal;
                        Integer num = mwCollectRecordService.count(new QueryWrapper<MwCollectRecord>().lambda()//
                                .between(MwCollectRecord::getCreateTime, DateUtil.format(dto.getStartTime(), "yyyy-MM-dd HH:mm:ss"), DateUtil.format(dto.getEndTime(), "yyyy-MM-dd HH:mm:ss"))//
                                .in(MwCollectRecord::getHospitalId, childrenList.stream().map(SysDepartment::getId).collect(Collectors.toList()))//
                                .eq(MwCollectRecord::getDelFlag, 0)//
                                .eq(MwCollectRecord::getAuditStatus, MedicalWasteEnum.MedicalWasteAuditStatusEnum.PASS.getStatus())
                                .eq(MwCollectRecord::getSource, 2));
                        itemVO.getData().add(new BigDecimal(num));
                        if(numTotal>0){
                            itemVO.getData().add(new BigDecimal(num).divide(new BigDecimal(numTotal),4,BigDecimal.ROUND_UP).multiply(BigDecimal.valueOf(100)).setScale(2,BigDecimal.ROUND_UP));
                        }else{
                            itemVO.getData().add(new BigDecimal(0));
                        }
                        num2+=num;
                        num6+=num;subtotal+=num;
                        num =  mwCollectionAmendantRecordService.count(new QueryWrapper<MwCollectionAmendantRecord>().lambda()//
                                .between(MwCollectionAmendantRecord::getCreateTime, DateUtil.format(dto.getStartTime(), "yyyy-MM-dd HH:mm:ss"), DateUtil.format(dto.getEndTime(), "yyyy-MM-dd HH:mm:ss"))//
                                .in(MwCollectionAmendantRecord::getHospitalId, childrenList.stream().map(SysDepartment::getId).collect(Collectors.toList()))//
                                .eq(MwCollectionAmendantRecord::getDelFlag, 0)//);
                                .eq(MwCollectionAmendantRecord::getType, 1));
                        itemVO.getData().add(new BigDecimal(num));
                        if(numTotal>0){
                            itemVO.getData().add(new BigDecimal(num).divide(new BigDecimal(numTotal),4,BigDecimal.ROUND_UP).multiply(BigDecimal.valueOf(100)).setScale(2,BigDecimal.ROUND_UP));
                        }else{
                            itemVO.getData().add(new BigDecimal(0));
                        }
                        num3+=num;
                        num6+=num;subtotal+=num;
                        num =  mwCollectionAmendantRecordService.count(new QueryWrapper<MwCollectionAmendantRecord>().lambda()//
                                .between(MwCollectionAmendantRecord::getCreateTime, DateUtil.format(dto.getStartTime(), "yyyy-MM-dd HH:mm:ss"), DateUtil.format(dto.getEndTime(), "yyyy-MM-dd HH:mm:ss"))//
                                .in(MwCollectionAmendantRecord::getHospitalId, childrenList.stream().map(SysDepartment::getId).collect(Collectors.toList()))//
                                .eq(MwCollectionAmendantRecord::getDelFlag, 0)//);
                                .eq(MwCollectionAmendantRecord::getType, 2));
                        itemVO.getData().add(new BigDecimal(num));
                        if(numTotal>0){
                            itemVO.getData().add(new BigDecimal(num).divide(new BigDecimal(numTotal),4,BigDecimal.ROUND_UP).multiply(BigDecimal.valueOf(100)).setScale(2,BigDecimal.ROUND_UP));
                        }else{
                            itemVO.getData().add(new BigDecimal(0));
                        }
                        num4+=num;
                        num6+=num;subtotal+=num;
                        num =  mwCollectionAmendantRecordService.count(new QueryWrapper<MwCollectionAmendantRecord>().lambda()//
                                .between(MwCollectionAmendantRecord::getCreateTime, DateUtil.format(dto.getStartTime(), "yyyy-MM-dd HH:mm:ss"), DateUtil.format(dto.getEndTime(), "yyyy-MM-dd HH:mm:ss"))//
                                .in(MwCollectionAmendantRecord::getHospitalId, childrenList.stream().map(SysDepartment::getId).collect(Collectors.toList()))//
                                .eq(MwCollectionAmendantRecord::getDelFlag, 0)//);
                                .eq(MwCollectionAmendantRecord::getType, 3));
                        itemVO.getData().add(new BigDecimal(num));
                        if(numTotal>0){
                            itemVO.getData().add(new BigDecimal(num).divide(new BigDecimal(numTotal),4,BigDecimal.ROUND_UP).multiply(BigDecimal.valueOf(100)).setScale(2,BigDecimal.ROUND_UP));
                        }else{
                            itemVO.getData().add(new BigDecimal(0));
                        }
                        num5+=num;
                        num6+=num;subtotal+=num;
                        itemVO.getData().add(new BigDecimal(subtotal));
                        if(numTotal>0){
                            itemVO.getData().add(new BigDecimal(subtotal).divide(new BigDecimal(numTotal),4,BigDecimal.ROUND_UP).multiply(BigDecimal.valueOf(100)).setScale(2,BigDecimal.ROUND_UP));
                        }else{
                            itemVO.getData().add(new BigDecimal(0));
                        }
                    }

                }
                voList.add(itemVO);
            }
        }else{//医疗机构统计
            //for (SysDepartment sysDepartment : regionList) {

                //获取下级组织
                List<SysDepartment> childrenList = new ArrayList<>();
                if(CollectionUtils.isNotEmpty(sysDepartmentInformationList)){
                    childrenList = sysDepartmentService.list(new QueryWrapper<SysDepartment>().lambda()
                            .likeRight(SysDepartment::getTreeCode, department.getTreeCode())//
                            .in(SysDepartment::getId, sysDepartmentInformationList.stream().map(SysDepartmentInformation::getDepartmentId).collect(Collectors.toList()))
                            .eq(SysDepartment::getOrgType, DepartmentEnum.OrgTypeEnum.HOSPITAL.getType()));
                }else{
                    childrenList = sysDepartmentService.list(new QueryWrapper<SysDepartment>().lambda()
                            .likeRight(SysDepartment::getTreeCode, department.getTreeCode()).eq(SysDepartment::getOrgType, DepartmentEnum.OrgTypeEnum.HOSPITAL.getType()));
                }

                for(SysDepartment sysDepartment1:childrenList){
                    Integer subtotal=0;
                    DepartmentReportItemVO itemVO = new DepartmentReportItemVO();
                    itemVO.setKey(sysDepartment1.getId());
                    itemVO.setName(sysDepartment1.getDepartName());
                    itemVO.setData(new ArrayList<>());
                    if (CollectionUtils.isNotEmpty(childrenList)) {
                        if(CollectionUtils.isNotEmpty(sysDepartmentInformationList)){
                            Integer numTotal = mwCollectRecordService.count(new QueryWrapper<MwCollectRecord>().lambda()//
                                    .between(MwCollectRecord::getCreateTime, DateUtil.format(dto.getStartTime(), "yyyy-MM-dd HH:mm:ss"), DateUtil.format(dto.getEndTime(), "yyyy-MM-dd HH:mm:ss"))//
                                    .eq(MwCollectRecord::getHospitalId, sysDepartment1.getId())//
                                    .in(MwCollectRecord::getHospitalId, sysDepartmentInformationList.stream().map(SysDepartmentInformation::getDepartmentId).collect(Collectors.toList()))//
                                    .eq(MwCollectRecord::getDelFlag, 0)//
                                    .eq(MwCollectRecord::getAuditStatus, MedicalWasteEnum.MedicalWasteAuditStatusEnum.PASS.getStatus()));
                            itemVO.getData().add(new BigDecimal(numTotal));
                            num1+=numTotal;
                            Integer num = mwCollectRecordService.count(new QueryWrapper<MwCollectRecord>().lambda()//
                                    .between(MwCollectRecord::getCreateTime, DateUtil.format(dto.getStartTime(), "yyyy-MM-dd HH:mm:ss"), DateUtil.format(dto.getEndTime(), "yyyy-MM-dd HH:mm:ss"))//
                                    .eq(MwCollectRecord::getHospitalId, sysDepartment1.getId())//
                                    .in(MwCollectRecord::getHospitalId, sysDepartmentInformationList.stream().map(SysDepartmentInformation::getDepartmentId).collect(Collectors.toList()))//
                                    .eq(MwCollectRecord::getDelFlag, 0)//
                                    .eq(MwCollectRecord::getAuditStatus, MedicalWasteEnum.MedicalWasteAuditStatusEnum.PASS.getStatus())
                                    .eq(MwCollectRecord::getSource, 2));
                            itemVO.getData().add(new BigDecimal(num));
                            if(numTotal>0){
                                itemVO.getData().add(new BigDecimal(num).divide(new BigDecimal(numTotal),4,BigDecimal.ROUND_UP).multiply(BigDecimal.valueOf(100)).setScale(2,BigDecimal.ROUND_UP));
                            }else{
                                itemVO.getData().add(new BigDecimal(0));
                            }
                            num2+=num;
                            num6+=num;subtotal+=num;
                            num =  mwCollectionAmendantRecordService.count(new QueryWrapper<MwCollectionAmendantRecord>().lambda()//
                                    .between(MwCollectionAmendantRecord::getCreateTime, DateUtil.format(dto.getStartTime(), "yyyy-MM-dd HH:mm:ss"), DateUtil.format(dto.getEndTime(), "yyyy-MM-dd HH:mm:ss"))//
                                    .eq(MwCollectionAmendantRecord::getHospitalId, sysDepartment1.getId())//
                                    .in(MwCollectionAmendantRecord::getHospitalId, sysDepartmentInformationList.stream().map(SysDepartmentInformation::getDepartmentId).collect(Collectors.toList()))//
                                    .eq(MwCollectionAmendantRecord::getDelFlag, 0)//);
                                    .eq(MwCollectionAmendantRecord::getType, 1));
                            itemVO.getData().add(new BigDecimal(num));
                            if(numTotal>0){
                                itemVO.getData().add(new BigDecimal(num).divide(new BigDecimal(numTotal),4,BigDecimal.ROUND_UP).multiply(BigDecimal.valueOf(100)).setScale(2,BigDecimal.ROUND_UP));
                            }else{
                                itemVO.getData().add(new BigDecimal(0));
                            }
                            num3+=num;
                            num6+=num;subtotal+=num;
                            num =  mwCollectionAmendantRecordService.count(new QueryWrapper<MwCollectionAmendantRecord>().lambda()//
                                    .between(MwCollectionAmendantRecord::getCreateTime, DateUtil.format(dto.getStartTime(), "yyyy-MM-dd HH:mm:ss"), DateUtil.format(dto.getEndTime(), "yyyy-MM-dd HH:mm:ss"))//
                                    .eq(MwCollectionAmendantRecord::getHospitalId, sysDepartment1.getId())//
                                    .in(MwCollectionAmendantRecord::getHospitalId, sysDepartmentInformationList.stream().map(SysDepartmentInformation::getDepartmentId).collect(Collectors.toList()))//
                                    .eq(MwCollectionAmendantRecord::getDelFlag, 0)//);
                                    .eq(MwCollectionAmendantRecord::getType, 2));
                            itemVO.getData().add(new BigDecimal(num));
                            if(numTotal>0){
                                itemVO.getData().add(new BigDecimal(num).divide(new BigDecimal(numTotal),4,BigDecimal.ROUND_UP).multiply(BigDecimal.valueOf(100)).setScale(2,BigDecimal.ROUND_UP));
                            }else{
                                itemVO.getData().add(new BigDecimal(0));
                            }
                            num4+=num;
                            num6+=num;subtotal+=num;
                            num =  mwCollectionAmendantRecordService.count(new QueryWrapper<MwCollectionAmendantRecord>().lambda()//
                                    .between(MwCollectionAmendantRecord::getCreateTime, DateUtil.format(dto.getStartTime(), "yyyy-MM-dd HH:mm:ss"), DateUtil.format(dto.getEndTime(), "yyyy-MM-dd HH:mm:ss"))//
                                    .eq(MwCollectionAmendantRecord::getHospitalId, sysDepartment1.getId())//
                                    .in(MwCollectionAmendantRecord::getHospitalId, sysDepartmentInformationList.stream().map(SysDepartmentInformation::getDepartmentId).collect(Collectors.toList()))//
                                    .eq(MwCollectionAmendantRecord::getDelFlag, 0)//);
                                    .eq(MwCollectionAmendantRecord::getType, 3));
                            itemVO.getData().add(new BigDecimal(num));
                            if(numTotal>0){
                                itemVO.getData().add(new BigDecimal(num).divide(new BigDecimal(numTotal),4,BigDecimal.ROUND_UP).multiply(BigDecimal.valueOf(100)).setScale(2,BigDecimal.ROUND_UP));
                            }else{
                                itemVO.getData().add(new BigDecimal(0));
                            }
                            num5+=num;
                            num6+=num;subtotal+=num;

                            itemVO.getData().add(new BigDecimal(subtotal));
                            if(numTotal>0){
                                itemVO.getData().add(new BigDecimal(subtotal).divide(new BigDecimal(numTotal),4,BigDecimal.ROUND_UP).multiply(BigDecimal.valueOf(100)).setScale(2,BigDecimal.ROUND_UP));
                            }else{
                                itemVO.getData().add(new BigDecimal(0));
                            }
                        }else{
                            Integer numTotal = mwCollectRecordService.count(new QueryWrapper<MwCollectRecord>().lambda()//
                                    .between(MwCollectRecord::getCreateTime, DateUtil.format(dto.getStartTime(), "yyyy-MM-dd HH:mm:ss"), DateUtil.format(dto.getEndTime(), "yyyy-MM-dd HH:mm:ss"))//
                                    .eq(MwCollectRecord::getHospitalId, sysDepartment1.getId())//
                                    .eq(MwCollectRecord::getDelFlag, 0)//
                                    .eq(MwCollectRecord::getAuditStatus, MedicalWasteEnum.MedicalWasteAuditStatusEnum.PASS.getStatus()));
                            itemVO.getData().add(new BigDecimal(numTotal));
                            num1+=numTotal;
                            Integer num = mwCollectRecordService.count(new QueryWrapper<MwCollectRecord>().lambda()//
                                    .between(MwCollectRecord::getCreateTime, DateUtil.format(dto.getStartTime(), "yyyy-MM-dd HH:mm:ss"), DateUtil.format(dto.getEndTime(), "yyyy-MM-dd HH:mm:ss"))//
                                    .eq(MwCollectRecord::getHospitalId, sysDepartment1.getId())//
                                    .eq(MwCollectRecord::getDelFlag, 0)//
                                    .eq(MwCollectRecord::getAuditStatus, MedicalWasteEnum.MedicalWasteAuditStatusEnum.PASS.getStatus())
                                    .eq(MwCollectRecord::getSource, 2));
                            itemVO.getData().add(new BigDecimal(num));
                            if(numTotal>0){
                                itemVO.getData().add(new BigDecimal(num).divide(new BigDecimal(numTotal),4,BigDecimal.ROUND_UP).multiply(BigDecimal.valueOf(100)).setScale(2,BigDecimal.ROUND_UP));
                            }else{
                                itemVO.getData().add(new BigDecimal(0));
                            }
                            num2+=num;
                            num6+=num;subtotal+=num;
                            num =  mwCollectionAmendantRecordService.count(new QueryWrapper<MwCollectionAmendantRecord>().lambda()//
                                    .between(MwCollectionAmendantRecord::getCreateTime, DateUtil.format(dto.getStartTime(), "yyyy-MM-dd HH:mm:ss"), DateUtil.format(dto.getEndTime(), "yyyy-MM-dd HH:mm:ss"))//
                                    .eq(MwCollectionAmendantRecord::getHospitalId, sysDepartment1.getId())//
                                    .eq(MwCollectionAmendantRecord::getDelFlag, 0)//);
                                    .eq(MwCollectionAmendantRecord::getType, 1));
                            itemVO.getData().add(new BigDecimal(num));
                            if(numTotal>0){
                                itemVO.getData().add(new BigDecimal(num).divide(new BigDecimal(numTotal),4,BigDecimal.ROUND_UP).multiply(BigDecimal.valueOf(100)).setScale(2,BigDecimal.ROUND_UP));
                            }else{
                                itemVO.getData().add(new BigDecimal(0));
                            }
                            num3+=num;
                            num6+=num;subtotal+=num;
                            num =  mwCollectionAmendantRecordService.count(new QueryWrapper<MwCollectionAmendantRecord>().lambda()//
                                    .between(MwCollectionAmendantRecord::getCreateTime, DateUtil.format(dto.getStartTime(), "yyyy-MM-dd HH:mm:ss"), DateUtil.format(dto.getEndTime(), "yyyy-MM-dd HH:mm:ss"))//
                                    .eq(MwCollectionAmendantRecord::getHospitalId, sysDepartment1.getId())//
                                    .eq(MwCollectionAmendantRecord::getDelFlag, 0)//);
                                    .eq(MwCollectionAmendantRecord::getType, 2));
                            itemVO.getData().add(new BigDecimal(num));
                            if(numTotal>0){
                                itemVO.getData().add(new BigDecimal(num).divide(new BigDecimal(numTotal),4,BigDecimal.ROUND_UP).multiply(BigDecimal.valueOf(100)).setScale(2,BigDecimal.ROUND_UP));
                            }else{
                                itemVO.getData().add(new BigDecimal(0));
                            }
                            num4+=num;
                            num6+=num;subtotal+=num;
                            num =  mwCollectionAmendantRecordService.count(new QueryWrapper<MwCollectionAmendantRecord>().lambda()//
                                    .between(MwCollectionAmendantRecord::getCreateTime, DateUtil.format(dto.getStartTime(), "yyyy-MM-dd HH:mm:ss"), DateUtil.format(dto.getEndTime(), "yyyy-MM-dd HH:mm:ss"))//
                                    .eq(MwCollectionAmendantRecord::getHospitalId, sysDepartment1.getId())//
                                    .eq(MwCollectionAmendantRecord::getDelFlag, 0)//);
                                    .eq(MwCollectionAmendantRecord::getType, 3));
                            itemVO.getData().add(new BigDecimal(num));
                            if(numTotal>0){
                                itemVO.getData().add(new BigDecimal(num).divide(new BigDecimal(numTotal),4,BigDecimal.ROUND_UP).multiply(BigDecimal.valueOf(100)).setScale(2,BigDecimal.ROUND_UP));
                            }else{
                                itemVO.getData().add(new BigDecimal(0));
                            }
                            num5+=num;
                            num6+=num;subtotal+=num;
                            itemVO.getData().add(new BigDecimal(subtotal));
                            if(numTotal>0){
                                itemVO.getData().add(new BigDecimal(subtotal).divide(new BigDecimal(numTotal),4,BigDecimal.ROUND_UP).multiply(BigDecimal.valueOf(100)).setScale(2,BigDecimal.ROUND_UP));
                            }else{
                                itemVO.getData().add(new BigDecimal(0));
                            }
                        }

                    }
                    voList.add(itemVO);
                }


           // }
        }

        //合计
        DepartmentReportItemVO totalItemVO = new DepartmentReportItemVO();
        totalItemVO.setKey(-2);
        totalItemVO.setName("合计");
        totalItemVO.setData(new ArrayList<>());
        totalItemVO.getData().add(new BigDecimal(num1));
        totalItemVO.getData().add(new BigDecimal(num2));
        if(num1>0){
            totalItemVO.getData().add(new BigDecimal(num2).divide(new BigDecimal(num1),4,BigDecimal.ROUND_UP).multiply(BigDecimal.valueOf(100)).setScale(2,BigDecimal.ROUND_UP));
        }else{
            totalItemVO.getData().add(new BigDecimal(0));
        }
        totalItemVO.getData().add(new BigDecimal(num3));
        if(num1>0){
            totalItemVO.getData().add(new BigDecimal(num3).divide(new BigDecimal(num1),4,BigDecimal.ROUND_UP).multiply(BigDecimal.valueOf(100)).setScale(2,BigDecimal.ROUND_UP));
        }else{
            totalItemVO.getData().add(new BigDecimal(0));
        }
        totalItemVO.getData().add(new BigDecimal(num4));
        if(num1>0){
            totalItemVO.getData().add(new BigDecimal(num4).divide(new BigDecimal(num1),4,BigDecimal.ROUND_UP).multiply(BigDecimal.valueOf(100)).setScale(2,BigDecimal.ROUND_UP));
        }else{
            totalItemVO.getData().add(new BigDecimal(0));
        }
        totalItemVO.getData().add(new BigDecimal(num5));
        if(num1>0){
            totalItemVO.getData().add(new BigDecimal(num5).divide(new BigDecimal(num1),4,BigDecimal.ROUND_UP).multiply(BigDecimal.valueOf(100)).setScale(2,BigDecimal.ROUND_UP));
        }else{
            totalItemVO.getData().add(new BigDecimal(0));
        }
        totalItemVO.getData().add(new BigDecimal(num6));
        if(num1>0){
            totalItemVO.getData().add(new BigDecimal(num6).divide(new BigDecimal(num1),4,BigDecimal.ROUND_UP).multiply(BigDecimal.valueOf(100)).setScale(2,BigDecimal.ROUND_UP));
        }else{
            totalItemVO.getData().add(new BigDecimal(0));
        }
        voList.add(0,totalItemVO);
        vo.setList(voList);
        return vo;
    }

    public void exportCollectionAmendantReport(HttpServletResponse response, ReportCollectionAmendantDTO dto) throws IOException {

        String fileName = "";
        ExcelWriter writer = null;
        fileName = "数据修改统计";
        writer = new ExcelWriter(exportCollectionAmendant(dto, fileName), fileName);
        if (writer != null) {
            response.setContentType("application/octet-stream;charset=utf-8");
            response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(fileName, "UTF-8") + ".xlsx");
            writer.flush(response.getOutputStream(), true);
            writer.close();
        }
    }

    @Autowired
    private ISysDictItemService sysDictItemService;
    /**
     * 医疗机构统计
     *
     * @param dto
     * @return
     */
    public MedicalReportVO getMedicalReportList(MedicalReportDTO dto) {

        SysDepartment department = sysDepartmentService.getById(dto.getDepartmentId());
        if (department == null) {
            throw new BusinessException(ErrorCode.ERR_500, "区域不存在");
        }
        if (!department.getOrgType().equals(DepartmentEnum.OrgTypeEnum.AREA.getType())) {
            throw new BusinessException(ErrorCode.ERR_500, "区域不存在");
        }
        MedicalReportVO medicalReportVO=new MedicalReportVO();
        medicalReportVO.setDepartmentName(department.getDepartName());
        dto.setTreeCode(department.getTreeCode());
        //获取机构信息
        List<SysDepartmentInformationReportVO> informationList = sysDepartmentInformationService.getDepartmentInformationList(dto);
        //获取列表表头
        List<SysDictItem> sysDictItems=sysDictItemService.list(new QueryWrapper<SysDictItem>()
                .eq("dict_id",5)
                .orderByAsc("sort_order"));
        Map<String,String> legendMap=new HashMap<>();
        legendMap.put("0","暂存间");
        for(SysDictItem sysDictItem:sysDictItems){
            legendMap.put(sysDictItem.getId()+"",sysDictItem.getItemText());
        }
        medicalReportVO.setLegend(legendMap.values());
        //拼接数据
        Set<String> legendSet = legendMap.keySet(); //取出所有的key值
        Long[] dataTotal=new Long[legendSet.size()];
        if(informationList==null || informationList.size()==0){
            return medicalReportVO;
        }
        for(SysDepartmentInformationReportVO vo:informationList){
            if(vo.getIsCourts()==null){
                vo.setIsCourtsStr("");
            }
            Long[] data=new Long[legendSet.size()];
            //获取科室汇总数量
            List<Map<String,Object>>  mapList1=sysDepartmentInformationService.getDepartmentNumber(vo.getTreeCode());
            Integer i=0;
            for(String setStr:legendSet){
                data[i]=0L;
                if(dataTotal[i]==null){
                    dataTotal[i] = 0l;
                }
                for(Map<String,Object> map : mapList1){
                    if(map.get("officeType").toString().equals(setStr)){
                        data[i]=Long.valueOf(map.get("number").toString());
                        dataTotal[i] += Long.valueOf(map.get("number").toString());
                    }
                }
                i++;
            }
            vo.setData(data);

        }
        SysDepartmentInformationReportVO totalVo=new SysDepartmentInformationReportVO();
        totalVo.setData(dataTotal);
        totalVo.setDepartmentName("合计");
        informationList.add(0,totalVo);
        medicalReportVO.setList(informationList);
        return medicalReportVO;
    }

    public void exportHospitalReport(HttpServletResponse response, MedicalReportDTO dto) throws IOException {

        String fileName = "";
        ExcelWriter writer = null;
        fileName = "医疗机构统计";
        writer = new ExcelWriter(exportHospitalReport(dto, fileName), fileName);
        if (writer != null) {
            response.setContentType("application/octet-stream;charset=utf-8");
            response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(fileName, "UTF-8") + ".xlsx");
            writer.flush(response.getOutputStream(), true);
            writer.close();
        }
    }

    @Autowired
    private ReportBiz reportBiz;

    @Autowired
    private IMwCollectRecordDaySummaryService mwCollectRecordDaySummaryService;
    /**
     * 医院产废报表
     *
     * @param dto
     * @return
     */
    public DepartmentReportVO getHospitalReportList(CollectRecordSummaryDTO dto) {

        SysDepartment department = sysDepartmentService.getById(dto.getDepartmentId());
        if (department == null) {
            throw new BusinessException(ErrorCode.ERR_500, "区域不存在");
        }
        if (!department.getOrgType().equals(DepartmentEnum.OrgTypeEnum.AREA.getType())) {
            throw new BusinessException(ErrorCode.ERR_500, "区域不存在");
        }
        DepartmentReportVO vo = new DepartmentReportVO();
        vo.setDepartmentName(department.getDepartName());
        List<SysDictItem> wasteTypeList = reportBiz.getWasteTypeList();
        if (CollectionUtils.isEmpty(wasteTypeList)) {
            return vo;
        }
        vo.setLegend(wasteTypeList.stream().map(SysDictItem::getItemText).collect(Collectors.toList()));
        vo.getLegend().add("小计");
        //
        List<SysDepartmentInformation> sysDepartmentInformationList = new ArrayList<>();
        if(dto.getDepartmentLevel()!=null || dto.getDepartmentProperty()!=null || dto.getDepartmentType()!=null || dto.getIsCourts()!=null){
            QueryWrapper<SysDepartmentInformation> wrapper = new QueryWrapper<SysDepartmentInformation>();
            wrapper.lambda();
            if(dto.getDepartmentLevel()!=null) wrapper.eq("department_level",dto.getDepartmentLevel());
            if(dto.getDepartmentProperty()!=null) wrapper.eq("department_property",dto.getDepartmentProperty());
            if(dto.getDepartmentType()!=null) wrapper.eq("department_type",dto.getDepartmentType());
            if(dto.getIsCourts()!=null) wrapper.eq("is_courts",dto.getIsCourts());
            sysDepartmentInformationList = sysDepartmentInformationService.list(wrapper);
        }
        List<SysDepartment> hospitalList = sysDepartmentService.list(new QueryWrapper<SysDepartment>()//
                .lambda()//
                .likeRight(SysDepartment::getTreeCode, department.getTreeCode())//
                .in(sysDepartmentInformationList.size()>0,SysDepartment::getId, sysDepartmentInformationList.stream().map(SysDepartmentInformation::getDepartmentId).collect(Collectors.toList()))//
                .eq(SysDepartment::getOrgType, DepartmentEnum.OrgTypeEnum.HOSPITAL.getType()));//
        if (CollectionUtils.isEmpty(hospitalList)) {
            return vo;
        }
        List<MwCollectRecordDaySummary> daySummaries = mwCollectRecordDaySummaryService.list(new QueryWrapper<MwCollectRecordDaySummary>()//
                .lambda()//
                .in(MwCollectRecordDaySummary::getHospitalId, hospitalList.stream().map(SysDepartment::getId).collect(Collectors.toList()))//
                .between(dto.getStartTime()!=null && dto.getEndTime()!=null,MwCollectRecordDaySummary::getCreateTime, DateUtil.format(dto.getStartTime(), "yyyy-MM-dd HH:mm:ss"), DateUtil.format(dto.getEndTime(), "yyyy-MM-dd HH:mm:ss"))//
                );
        Map<Integer, List<MwCollectRecordDaySummary>> mwCollectRecordMap = daySummaries.stream().collect(Collectors.groupingBy(MwCollectRecordDaySummary::getHospitalId));
        //
        List<DepartmentReportItemVO> voList = buildDepartmentReportItemVOList(wasteTypeList, hospitalList, daySummaries, mwCollectRecordMap);
        vo.setList(voList);
        return vo;
    }

    private List<DepartmentReportItemVO> buildDepartmentReportItemVOList(List<SysDictItem> wasteTypeList, List<SysDepartment> officeList, List<MwCollectRecordDaySummary> daySummaries, Map<Integer, List<MwCollectRecordDaySummary>> mwCollectRecordMap) {

        List<DepartmentReportItemVO> voList = new ArrayList<>();
        for (SysDepartment office : officeList) {
            DepartmentReportItemVO itemVO = new DepartmentReportItemVO();
            itemVO.setKey(office.getId());
            itemVO.setName(office.getDepartName());
            itemVO.setData(new ArrayList<>());
            //
            BigDecimal totalCount = BigDecimal.ZERO;
            BigDecimal totalWeight = BigDecimal.ZERO;
            List<MwCollectRecordDaySummary> tempList = mwCollectRecordMap.getOrDefault(office.getId(), new ArrayList<>());
            for (SysDictItem sysDictItem : wasteTypeList) {
                BigDecimal weight = tempList.stream().filter(e -> e.getWasteType().equals(sysDictItem.getId())).map(MwCollectRecordDaySummary::getWeight).reduce(BigDecimal::add).orElse(BigDecimal.ZERO).setScale(2, BigDecimal.ROUND_HALF_UP);
                BigDecimal count = tempList.stream().filter(e -> e.getWasteType().equals(sysDictItem.getId())).map(MwCollectRecordDaySummary::getAmount).reduce(BigDecimal::add).orElse(BigDecimal.ZERO).setScale(2, BigDecimal.ROUND_HALF_UP);
                itemVO.getData().add(count);
                itemVO.getData().add(weight);
                //
                totalCount = totalCount .add(count);
                totalWeight = totalWeight.add(weight);
            }
            itemVO.getData().add(totalCount);
            itemVO.getData().add(totalWeight);
            voList.add(itemVO);
        }
        //合计
        DepartmentReportItemVO totalItemVO = new DepartmentReportItemVO();
        totalItemVO.setKey(-2);
        totalItemVO.setName("合计");
        totalItemVO.setData(new ArrayList<>());
        BigDecimal totalCount = BigDecimal.ZERO;
        BigDecimal totalWeight = BigDecimal.ZERO;
        for (SysDictItem sysDictItem : wasteTypeList) {
            BigDecimal count = daySummaries.stream().filter(e -> e.getWasteType().equals(sysDictItem.getId())).map(MwCollectRecordDaySummary::getAmount).reduce(BigDecimal::add).orElse(BigDecimal.ZERO).setScale(2, BigDecimal.ROUND_HALF_UP);
            BigDecimal weight = daySummaries.stream().filter(e -> e.getWasteType().equals(sysDictItem.getId())).map(MwCollectRecordDaySummary::getWeight).reduce(BigDecimal::add).orElse(BigDecimal.ZERO).setScale(2, BigDecimal.ROUND_HALF_UP);
            totalItemVO.getData().add(count);
            totalItemVO.getData().add(weight);
            //
            totalCount = totalCount .add(count);
            totalWeight = totalWeight.add(weight);
        }
        totalItemVO.getData().add(totalCount);
        totalItemVO.getData().add(totalWeight);
        voList.add(0,totalItemVO);
        return voList;
    }

    /**
     * 区域产废报表
     *
     * @param dto
     * @return
     */
    public DepartmentReportVO getRegionReportList(CollectRecordSummaryDTO dto) {

        SysDepartment department = sysDepartmentService.getById(dto.getDepartmentId());
        if (department == null) {
            throw new BusinessException(ErrorCode.ERR_500, "区域不存在");
        }
        if (!department.getOrgType().equals(DepartmentEnum.OrgTypeEnum.AREA.getType())) {
            throw new BusinessException(ErrorCode.ERR_500, "区域不存在");
        }
        DepartmentReportVO vo = new DepartmentReportVO();
        vo.setDepartmentName(department.getDepartName());
        List<SysDictItem> wasteTypeList = reportBiz.getWasteTypeList();
        if (CollectionUtils.isEmpty(wasteTypeList)) {
            return vo;
        }
        vo.setLegend(wasteTypeList.stream().map(SysDictItem::getItemText).collect(Collectors.toList()));
        vo.getLegend().add("小计");
        //
        List<SysDepartment> regionList = sysDepartmentService.list(new QueryWrapper<SysDepartment>()//
                .lambda()//
                .eq(SysDepartment::getParentId, department.getId())//
                .eq(SysDepartment::getOrgType, DepartmentEnum.OrgTypeEnum.AREA.getType()));//
        if (CollectionUtils.isEmpty(regionList)) {
            return vo;
        }
        List<SysDepartmentInformation> sysDepartmentInformationList = new ArrayList<>();
        //if(dto.getDepartmentLevel()!=null || dto.getDepartmentProperty()!=null || dto.getDepartmentType()!=null || dto.getIsCourts()!=null){
            QueryWrapper<SysDepartmentInformation> wrapper = new QueryWrapper<SysDepartmentInformation>();
            wrapper.lambda();
            if(dto.getDepartmentLevel()!=null) wrapper.eq("department_level",dto.getDepartmentLevel());
            if(dto.getDepartmentProperty()!=null) wrapper.eq("department_property",dto.getDepartmentProperty());
            if(dto.getDepartmentType()!=null) wrapper.eq("department_type",dto.getDepartmentType());
            if(dto.getIsCourts()!=null) wrapper.eq("is_courts",dto.getIsCourts());
            sysDepartmentInformationList = sysDepartmentInformationService.list(wrapper);
        //}
        List<MwCollectRecordDaySummary> totalMwCollectRecordList = new ArrayList<>();
        List<DepartmentReportItemVO> voList = new ArrayList<>();
        for (SysDepartment sysDepartment : regionList) {
            DepartmentReportItemVO itemVO = new DepartmentReportItemVO();
            itemVO.setKey(sysDepartment.getId());
            itemVO.setName(sysDepartment.getDepartName());
            itemVO.setData(new ArrayList<>());
            List<SysDepartment> childrenList = null;
            //获取下级组织
            if(sysDepartmentInformationList.size()>0){
                childrenList = sysDepartmentService.list(new QueryWrapper<SysDepartment>().lambda()
                        .likeRight(SysDepartment::getTreeCode, sysDepartment.getTreeCode())
                        .in(SysDepartment::getId, sysDepartmentInformationList.stream().map(SysDepartmentInformation::getDepartmentId).collect(Collectors.toList()))//
                );
            }else {
                childrenList = sysDepartmentService.list(new QueryWrapper<SysDepartment>().lambda()
                        .likeRight(SysDepartment::getTreeCode, sysDepartment.getTreeCode())
                        .in(SysDepartment::getId, sysDepartmentInformationList.add(new SysDepartmentInformation()))
                        );
            }
            List<MwCollectRecordDaySummary> mwCollectRecordList = new ArrayList<>();
            if (CollectionUtils.isNotEmpty(childrenList)) {
                mwCollectRecordList = mwCollectRecordDaySummaryService.list(new QueryWrapper<MwCollectRecordDaySummary>().lambda()//
                        .in(MwCollectRecordDaySummary::getHospitalId, childrenList.stream().map(SysDepartment::getId).collect(Collectors.toList()))//
                        .between(dto.getStartTime()!=null && dto.getEndTime()!=null,MwCollectRecordDaySummary::getCreateTime, DateUtil.format(dto.getStartTime(), "yyyy-MM-dd HH:mm:ss"), DateUtil.format(dto.getEndTime(), "yyyy-MM-dd HH:mm:ss"))//
                );
                totalMwCollectRecordList.addAll(mwCollectRecordList);
            }
            BigDecimal totalCount = BigDecimal.ZERO;
            BigDecimal totalWeight = BigDecimal.ZERO;
            for (SysDictItem sysDictItem : wasteTypeList) {
                BigDecimal count = mwCollectRecordList.stream().filter(e -> e.getWasteType().equals(sysDictItem.getId())).map(MwCollectRecordDaySummary::getAmount).reduce(BigDecimal::add).orElse(BigDecimal.ZERO).setScale(0, BigDecimal.ROUND_HALF_UP);
                BigDecimal weight = mwCollectRecordList.stream().filter(e -> e.getWasteType().equals(sysDictItem.getId())).map(MwCollectRecordDaySummary::getWeight).reduce(BigDecimal::add).orElse(BigDecimal.ZERO).setScale(2, BigDecimal.ROUND_HALF_UP);
                itemVO.getData().add(count);
                itemVO.getData().add(weight);
                //
                totalCount = totalCount .add(count);
                totalWeight = totalWeight.add(weight);
            }
            itemVO.getData().add(totalCount);
            itemVO.getData().add(totalWeight);
            voList.add(itemVO);
        }
        //合计
        DepartmentReportItemVO totalItemVO = new DepartmentReportItemVO();
        totalItemVO.setKey(-2);
        totalItemVO.setName("合计");
        totalItemVO.setData(new ArrayList<>());
        BigDecimal totalCount = BigDecimal.ZERO;
        BigDecimal totalWeight = BigDecimal.ZERO;
        for (SysDictItem sysDictItem : wasteTypeList) {
            BigDecimal count = totalMwCollectRecordList.stream().filter(e -> e.getWasteType().equals(sysDictItem.getId())).map(MwCollectRecordDaySummary::getAmount).reduce(BigDecimal::add).orElse(BigDecimal.ZERO).setScale(0, BigDecimal.ROUND_HALF_UP);
            BigDecimal weight = totalMwCollectRecordList.stream().filter(e -> e.getWasteType().equals(sysDictItem.getId())).map(MwCollectRecordDaySummary::getWeight).reduce(BigDecimal::add).orElse(BigDecimal.ZERO).setScale(2, BigDecimal.ROUND_HALF_UP);
            totalItemVO.getData().add(count);
            totalItemVO.getData().add(weight);
            //
            totalCount = totalCount.add(count);
            totalWeight = totalWeight.add(weight);
        }
        totalItemVO.getData().add(totalCount);
        totalItemVO.getData().add(totalWeight);
        voList.add(0,totalItemVO);
        vo.setList(voList);
        return vo;
    }
    /**
     * 医院产废报表
     *
     * @param dto
     * @return
     */
    public DepartmentReportVO getHospitalStatementList(CollectRecordSummaryDTO dto) {

        SysDepartment department = sysDepartmentService.getById(dto.getDepartmentId());
        if (department == null) {
            throw new BusinessException(ErrorCode.ERR_500, "区域不存在");
        }
        if (!department.getOrgType().equals(DepartmentEnum.OrgTypeEnum.AREA.getType())) {
            throw new BusinessException(ErrorCode.ERR_500, "区域不存在");
        }
        DepartmentReportVO vo = new DepartmentReportVO();
        vo.setDepartmentName(department.getDepartName());
        List<SysDictItem> wasteTypeList = reportBiz.getWasteTypeList();
        if (CollectionUtils.isEmpty(wasteTypeList)) {
            return vo;
        }
        vo.setLegend(wasteTypeList.stream().map(SysDictItem::getItemText).collect(Collectors.toList()));
        vo.getLegend().add("小计");
        //
        List<SysDepartmentInformation> sysDepartmentInformationList = new ArrayList<>();
        if(dto.getDepartmentLevel()!=null || dto.getDepartmentProperty()!=null || dto.getDepartmentType()!=null || dto.getIsCourts()!=null){
            QueryWrapper<SysDepartmentInformation> wrapper = new QueryWrapper<SysDepartmentInformation>();
            wrapper.lambda();
            if(dto.getDepartmentLevel()!=null) wrapper.eq("department_level",dto.getDepartmentLevel());
            if(dto.getDepartmentProperty()!=null) wrapper.eq("department_property",dto.getDepartmentProperty());
            if(dto.getDepartmentType()!=null) wrapper.eq("department_type",dto.getDepartmentType());
            if(dto.getIsCourts()!=null) wrapper.eq("is_courts",dto.getIsCourts());
            sysDepartmentInformationList = sysDepartmentInformationService.list(wrapper);
        }
        List<SysDepartment> hospitalList = sysDepartmentService.list(new QueryWrapper<SysDepartment>()//
                .lambda()//
                .likeRight(SysDepartment::getTreeCode, department.getTreeCode())//
                .in(sysDepartmentInformationList.size()>0,SysDepartment::getId, sysDepartmentInformationList.stream().map(SysDepartmentInformation::getDepartmentId).collect(Collectors.toList()))//
                .eq(SysDepartment::getOrgType, DepartmentEnum.OrgTypeEnum.HOSPITAL.getType()));//
        if (CollectionUtils.isEmpty(hospitalList)) {
            return vo;
        }
        List<MwCollectRecordDaySummary> daySummaries = mwCollectRecordDaySummaryService.list(new QueryWrapper<MwCollectRecordDaySummary>()//
                .lambda()//
                .in(MwCollectRecordDaySummary::getHospitalId, hospitalList.stream().map(SysDepartment::getId).collect(Collectors.toList()))//
                .between(dto.getStartTime()!=null && dto.getEndTime()!=null,MwCollectRecordDaySummary::getCreateTime, DateUtil.format(dto.getStartTime(), "yyyy-MM-dd HH:mm:ss"), DateUtil.format(dto.getEndTime(), "yyyy-MM-dd HH:mm:ss"))//
        );
        vo.setList(buildDepartmentStatementItemVOList(wasteTypeList,daySummaries,dto));
        return vo;
    }

    private List<DepartmentReportItemVO> buildDepartmentStatementItemVOList(
            List<SysDictItem> wasteTypeList,
            List<MwCollectRecordDaySummary> tempList,
            CollectRecordSummaryDTO dto) {
        List<DepartmentReportItemVO> voList =  new ArrayList<>();
        //日期数组
        SimpleDateFormat sdf = new SimpleDateFormat(DEFAULT_PATTERN);
        List<String> dateList = DateUtil.getMonthBetween(sdf.format(dto.getStartTime()),sdf.format(dto.getEndTime()),dto.getStatisticalWayType());
        SimpleDateFormat sdfWayType = new SimpleDateFormat(YYYY_MM_DD);
        if(dto.getStatisticalWayType() == 4){//年
            sdfWayType = new SimpleDateFormat(yyyy);
        }else if(dto.getStatisticalWayType() == 2 || dto.getStatisticalWayType() == 3){//月
            sdfWayType = new SimpleDateFormat(yyyy_MM);
        }
        for(String date : dateList){
            DepartmentReportItemVO itemVO = new DepartmentReportItemVO();
            itemVO.setKey(null);
            itemVO.setName(null);
            itemVO.setName(date);
            itemVO.setData(new ArrayList<>());
            SimpleDateFormat finalSdfWayType = sdfWayType;
            BigDecimal totalCount = BigDecimal.ZERO;
            BigDecimal totalWeight = BigDecimal.ZERO;
            for (SysDictItem sysDictItem : wasteTypeList) {
                BigDecimal weight = tempList.stream().filter(e -> e.getWasteType().equals(sysDictItem.getId())
                        && finalSdfWayType.format(e.getCreateTime()).equals(date)
                ).map(MwCollectRecordDaySummary::getWeight).reduce(BigDecimal::add).orElse(BigDecimal.ZERO).setScale(2, BigDecimal.ROUND_HALF_UP);
                BigDecimal count = tempList.stream().filter(e -> e.getWasteType().equals(sysDictItem.getId())
                        && finalSdfWayType.format(e.getCreateTime()).equals(date)
                ).map(MwCollectRecordDaySummary::getAmount).reduce(BigDecimal::add).orElse(BigDecimal.ZERO).setScale(2, BigDecimal.ROUND_HALF_UP);
                itemVO.getData().add(count);
                itemVO.getData().add(weight);
                totalCount = totalCount .add(count);
                totalWeight = totalWeight.add(weight);
            }
            itemVO.getData().add(totalCount);
            itemVO.getData().add(totalWeight);
            voList.add(itemVO);
        }

        //合计
        DepartmentReportItemVO totalItemVO = new DepartmentReportItemVO();
        totalItemVO.setKey(-2);
        totalItemVO.setName("合计");
        totalItemVO.setData(new ArrayList<>());
        BigDecimal totalCount = BigDecimal.ZERO;
        BigDecimal totalWeight = BigDecimal.ZERO;
        for (SysDictItem sysDictItem : wasteTypeList) {
            BigDecimal count = tempList.stream().filter(e -> e.getWasteType().equals(sysDictItem.getId())).map(MwCollectRecordDaySummary::getAmount).reduce(BigDecimal::add).orElse(BigDecimal.ZERO).setScale(2, BigDecimal.ROUND_HALF_UP);
            BigDecimal weight = tempList.stream().filter(e -> e.getWasteType().equals(sysDictItem.getId())).map(MwCollectRecordDaySummary::getWeight).reduce(BigDecimal::add).orElse(BigDecimal.ZERO).setScale(2, BigDecimal.ROUND_HALF_UP);
            totalItemVO.getData().add(count);
            totalItemVO.getData().add(weight);
            //
            totalCount = totalCount .add(count);
            totalWeight = totalWeight.add(weight);
        }
        totalItemVO.getData().add(totalCount);
        totalItemVO.getData().add(totalWeight);
        voList.add(0,totalItemVO);
        return voList;
    }
    /**
     * 区域产废报表
     *
     * @param dto
     * @return
     */
    public DepartmentReportVO getRegionStatementList(CollectRecordSummaryDTO dto) {

        SysDepartment department = sysDepartmentService.getById(dto.getDepartmentId());
        if (department == null) {
            throw new BusinessException(ErrorCode.ERR_500, "区域不存在");
        }
        if (!department.getOrgType().equals(DepartmentEnum.OrgTypeEnum.AREA.getType())) {
            throw new BusinessException(ErrorCode.ERR_500, "区域不存在");
        }
        DepartmentReportVO vo = new DepartmentReportVO();
        vo.setDepartmentName(department.getDepartName());
        List<SysDictItem> wasteTypeList = reportBiz.getWasteTypeList();
        if (CollectionUtils.isEmpty(wasteTypeList)) {
            return vo;
        }
        vo.setLegend(wasteTypeList.stream().map(SysDictItem::getItemText).collect(Collectors.toList()));
        vo.getLegend().add("小计");
        //
        List<SysDepartment> regionList = sysDepartmentService.list(new QueryWrapper<SysDepartment>()//
                .lambda()//
                .eq(SysDepartment::getParentId, department.getId())//
                .eq(SysDepartment::getOrgType, DepartmentEnum.OrgTypeEnum.AREA.getType()));//
        if (CollectionUtils.isEmpty(regionList)) {
            return vo;
        }
        List<SysDepartmentInformation> sysDepartmentInformationList = new ArrayList<>();
        if(dto.getDepartmentLevel()!=null || dto.getDepartmentProperty()!=null || dto.getDepartmentType()!=null || dto.getIsCourts()!=null){
            QueryWrapper<SysDepartmentInformation> wrapper = new QueryWrapper<SysDepartmentInformation>();
            wrapper.lambda();
            if(dto.getDepartmentLevel()!=null) wrapper.eq("department_level",dto.getDepartmentLevel());
            if(dto.getDepartmentProperty()!=null) wrapper.eq("department_property",dto.getDepartmentProperty());
            if(dto.getDepartmentType()!=null) wrapper.eq("department_type",dto.getDepartmentType());
            if(dto.getIsCourts()!=null) wrapper.eq("is_courts",dto.getIsCourts());
            sysDepartmentInformationList = sysDepartmentInformationService.list(wrapper);
        }
        List<MwCollectRecordDaySummary> totalMwCollectRecordList = new ArrayList<>();
        List<SysDepartment> childrenListAll = new ArrayList<>();
        for (SysDepartment sysDepartment : regionList) {
            DepartmentReportItemVO itemVO = new DepartmentReportItemVO();
            itemVO.setKey(sysDepartment.getId());
            itemVO.setName(sysDepartment.getDepartName());
            itemVO.setData(new ArrayList<>());
            //获取下级组织
            List<SysDepartment> childrenList = sysDepartmentService.list(new QueryWrapper<SysDepartment>().lambda()
                    .likeRight(SysDepartment::getTreeCode, sysDepartment.getTreeCode())
                    .in(sysDepartmentInformationList.size()>0,SysDepartment::getId, sysDepartmentInformationList.stream().map(SysDepartmentInformation::getDepartmentId).collect(Collectors.toList()))//
            );
            childrenListAll = Stream.of(childrenListAll, childrenList)
                    .flatMap(Collection::stream).distinct().collect(Collectors.toList());
        }
        List<MwCollectRecordDaySummary> mwCollectRecordList = new ArrayList<>();
        if (CollectionUtils.isNotEmpty(childrenListAll)) {
            mwCollectRecordList = mwCollectRecordDaySummaryService.list(new QueryWrapper<MwCollectRecordDaySummary>().lambda()//
                    .in(MwCollectRecordDaySummary::getHospitalId, childrenListAll.stream().map(SysDepartment::getId).collect(Collectors.toList()))//
                    .between(dto.getStartTime()!=null && dto.getEndTime()!=null,MwCollectRecordDaySummary::getCreateTime, DateUtil.format(dto.getStartTime(), "yyyy-MM-dd HH:mm:ss"), DateUtil.format(dto.getEndTime(), "yyyy-MM-dd HH:mm:ss"))//
            );
            totalMwCollectRecordList.addAll(mwCollectRecordList);
        }
        vo.setList(buildDepartmentStatementItemVOList(wasteTypeList,totalMwCollectRecordList,dto));
        return vo;
    }



    /**
     * 预警级别统计(区域)
     *
     * @param dto
     * @return
     */
    public CollectionWarningLevelReportVO getWarningRegionLevelReportList(CollectionWarningLevelDTO dto) {
        SysDepartment department = sysDepartmentService.getById(dto.getDepartmentId());
        if (department == null) {
            throw new BusinessException(ErrorCode.ERR_500, "区域不存在");
        }
        if (!department.getOrgType().equals(DepartmentEnum.OrgTypeEnum.AREA.getType())) {
            throw new BusinessException(ErrorCode.ERR_500, "区域不存在");
        }
        CollectionWarningLevelReportVO vo = new CollectionWarningLevelReportVO();
        vo.setDepartmentName(department.getDepartName());
        if(dto.getWarningStatisticalType()!=null && dto.getWarningStatisticalType()==2){
            vo.setLegend(Arrays.asList("未出医废预警","入库超时预警","入库前疑似遗失预警","出库超时预警","入库后疑似遗失预警","小计"));
        }else {
            vo.setLegend(Arrays.asList("一级预警","二级预警","三级预警","小计"));
        }
        //
        List<SysDepartment> regionList = sysDepartmentService.list(new QueryWrapper<SysDepartment>()//
                .lambda()//
                .eq(SysDepartment::getParentId, department.getId())//
                .eq(SysDepartment::getOrgType, DepartmentEnum.OrgTypeEnum.AREA.getType()));//
        if (CollectionUtils.isEmpty(regionList)) {
            return vo;
        }

        List<SysDepartmentInformation> sysDepartmentInformationList = new ArrayList<>();
        //if(dto.getDepartmentLevel()!=null || dto.getDepartmentProperty()!=null || dto.getDepartmentType()!=null || dto.getIsCourts()!=null){
            QueryWrapper<SysDepartmentInformation> wrapper = new QueryWrapper<SysDepartmentInformation>();
            wrapper.lambda();
            if(dto.getDepartmentLevel()!=null) wrapper.eq("department_level",dto.getDepartmentLevel());
            if(dto.getDepartmentProperty()!=null) wrapper.eq("department_property",dto.getDepartmentProperty());
            if(dto.getDepartmentType()!=null) wrapper.eq("department_type",dto.getDepartmentType());
            if(dto.getIsCourts()!=null) wrapper.eq("is_courts",dto.getIsCourts());
            sysDepartmentInformationList = sysDepartmentInformationService.list(wrapper);
        //}
        List<MwWarningRecord> totalMwCollectRecordList = new ArrayList<>();
        List<CollectionWarningLevelItemVO> voList = new ArrayList<>();
        for (SysDepartment sysDepartment : regionList) {
            CollectionWarningLevelItemVO itemVO = new CollectionWarningLevelItemVO();
            itemVO.setKey(sysDepartment.getId());
            itemVO.setName(sysDepartment.getDepartName());
            itemVO.setData(new ArrayList<>());
            List<SysDepartment> childrenList = null;
            //获取下级组织
            if(sysDepartmentInformationList.size()>0){
                childrenList = sysDepartmentService.list(new QueryWrapper<SysDepartment>().lambda()
                        .likeRight(SysDepartment::getTreeCode, sysDepartment.getTreeCode())
                        .in(SysDepartment::getId, sysDepartmentInformationList.stream().map(SysDepartmentInformation::getDepartmentId).collect(Collectors.toList()))//
                );
            }else {
                childrenList = sysDepartmentService.list(new QueryWrapper<SysDepartment>().lambda()
                        .likeRight(SysDepartment::getTreeCode, sysDepartment.getTreeCode())
                        .in(SysDepartment::getId,sysDepartmentInformationList.add(new SysDepartmentInformation()))//
                );
            }

            List<MwWarningRecord> mwWarningRecords = new ArrayList<>();
            if (CollectionUtils.isNotEmpty(childrenList)) {
                mwWarningRecords = warningRecordService.list(new QueryWrapper<MwWarningRecord>().lambda()//
                        .in(MwWarningRecord::getHospitalId, childrenList.stream().map(SysDepartment::getId).collect(Collectors.toList()))//
                        .between(dto.getStartTime()!=null && dto.getStartTime()!=null,MwWarningRecord::getCreateTime, DateUtil.format(dto.getStartTime(), "yyyy-MM-dd HH:mm:ss"), DateUtil.format(dto.getEndTime(), "yyyy-MM-dd HH:mm:ss"))//
                        .between(dto.getRelieveStartTime()!=null && dto.getRelieveStartTime()!=null,MwWarningRecord::getRelieveTime, DateUtil.format(dto.getRelieveStartTime(), "yyyy-MM-dd HH:mm:ss"), DateUtil.format(dto.getRelieveEndTime(), "yyyy-MM-dd HH:mm:ss"))//
                );
                totalMwCollectRecordList.addAll(mwWarningRecords);
            }
            voList.add(getLevelVoList(mwWarningRecords,itemVO,dto.getWarningStatisticalType()));
        }
        //合计
        CollectionWarningLevelItemVO totalItemVO = new CollectionWarningLevelItemVO();
        totalItemVO.setKey(-2);
        totalItemVO.setName("合计");
        totalItemVO.setData(new ArrayList<>());
        voList.add(0,getLevelVoList(totalMwCollectRecordList,totalItemVO,dto.getWarningStatisticalType()));
        vo.setList(voList);
        return vo;
    }
    //预警级别
    private CollectionWarningLevelItemVO getLevelVoList(List<MwWarningRecord> totalMwCollectRecordList,
                                                 CollectionWarningLevelItemVO itemVO,Integer warningStatisticalType
                                                 ){
        //总预警数
        BigDecimal warningTotalCount = new BigDecimal(0);
        //总反馈数
        BigDecimal feedbackTotalCount = new BigDecimal(0);
        //总解除数
        BigDecimal relieveTotalCount = new BigDecimal(0);
        List<Integer> legend=new ArrayList<>();
        if(warningStatisticalType!=null && warningStatisticalType==2) {
            //todo 预警类型
            //1：未出医废预警  3：入库超时预警  5：入库前疑似遗失预警  4：出库超时预警   10：入库后疑似遗失预警
            legend = Arrays.asList(1,3,5,4,10);
        }else {
            //todo 等级
            legend = Arrays.asList(1,2,3);
        }

        for(Integer l:legend){
            //预警数据
            Long warningCount = 0L;
            if(warningStatisticalType!=null && warningStatisticalType==2){
                warningCount =  totalMwCollectRecordList.stream().filter(e -> e.getType().equals(l)).count();
            }else {
                warningCount =  totalMwCollectRecordList.stream().filter(e -> e.getLevel().equals(l)).count();
            }
            warningTotalCount = warningTotalCount.add(new BigDecimal(warningCount));
            //反馈数据
            Long feedbackCount = 0L;
            if(warningStatisticalType!=null && warningStatisticalType==2){
                feedbackCount =  totalMwCollectRecordList.stream().filter(e -> e.getType().equals(l) && e.getMessageCount()>0).count();
            }else {
                feedbackCount = totalMwCollectRecordList.stream().filter(e -> e.getLevel().equals(l) && e.getMessageCount()>0).count();
            }

            feedbackTotalCount = feedbackTotalCount.add(new BigDecimal(feedbackCount));
            //解除数
            Long relieveCount = 0L;
            if(warningStatisticalType!=null && warningStatisticalType==2){
                relieveCount = totalMwCollectRecordList.stream().filter(e -> e.getType().equals(l) && e.getStatus().equals(MedicalWasteEnum.WarningRecordStatusEnum.PASS)).count();
            }else {
                relieveCount = totalMwCollectRecordList.stream().filter(e -> e.getLevel().equals(l) && e.getStatus().equals(MedicalWasteEnum.WarningRecordStatusEnum.PASS)).count();
            }
            relieveTotalCount = relieveTotalCount.add(new BigDecimal(relieveCount));

            itemVO.getData().add(new BigDecimal(warningCount));
            itemVO.getData().add(new BigDecimal(feedbackCount));

            BigDecimal feedbackPercentage = new BigDecimal(0);
            BigDecimal relievePercentage = new BigDecimal(0);
            if(warningCount>0){
                //反馈率
                feedbackPercentage = new BigDecimal(feedbackCount).divide(new BigDecimal(warningCount),4,BigDecimal.ROUND_UP).multiply(BigDecimal.valueOf(100)).setScale(2,BigDecimal.ROUND_UP);
                //解除率
                relievePercentage = new BigDecimal(relieveCount).divide(new BigDecimal(warningCount),4,BigDecimal.ROUND_UP).multiply(BigDecimal.valueOf(100)).setScale(2,BigDecimal.ROUND_UP);
            }
            itemVO.getData().add(feedbackPercentage);
            itemVO.getData().add(new BigDecimal(relieveCount));

            itemVO.getData().add(relievePercentage);
        }


        BigDecimal feedbackTotalPercentage = new BigDecimal(0);
        BigDecimal relieveTotalPercentage = new BigDecimal(0);
        if(warningTotalCount.intValue()>0){
            feedbackTotalPercentage = feedbackTotalCount.divide(warningTotalCount,4,BigDecimal.ROUND_UP).multiply(BigDecimal.valueOf(100)).setScale(2,BigDecimal.ROUND_UP);
            relieveTotalPercentage = relieveTotalCount.divide(warningTotalCount,4,BigDecimal.ROUND_UP).multiply(BigDecimal.valueOf(100)).setScale(2,BigDecimal.ROUND_UP);
        }
        itemVO.getData().add(warningTotalCount);
        itemVO.getData().add(feedbackTotalCount);
        itemVO.getData().add(feedbackTotalPercentage);
        itemVO.getData().add(relieveTotalCount);
        itemVO.getData().add(relieveTotalPercentage);
        return  itemVO;
    }

    /**
     * 预警级别统计(医院)
     *
     * @param dto
     * @return
     */
    public CollectionWarningLevelReportVO getWarningHospitalLevelReportList(CollectionWarningLevelDTO dto) {

        SysDepartment department = sysDepartmentService.getById(dto.getDepartmentId());
        if (department == null) {
            throw new BusinessException(ErrorCode.ERR_500, "区域不存在");
        }
        if (!department.getOrgType().equals(DepartmentEnum.OrgTypeEnum.AREA.getType())) {
            throw new BusinessException(ErrorCode.ERR_500, "区域不存在");
        }
        CollectionWarningLevelReportVO vo = new CollectionWarningLevelReportVO();
        vo.setDepartmentName(department.getDepartName());
        //
        List<SysDepartmentInformation> sysDepartmentInformationList = new ArrayList<>();
        if(dto.getDepartmentLevel()!=null || dto.getDepartmentProperty()!=null || dto.getDepartmentType()!=null || dto.getIsCourts()!=null){
            QueryWrapper<SysDepartmentInformation> wrapper = new QueryWrapper<SysDepartmentInformation>();
            wrapper.lambda();
            if(dto.getDepartmentLevel()!=null) wrapper.eq("department_level",dto.getDepartmentLevel());
            if(dto.getDepartmentProperty()!=null) wrapper.eq("department_property",dto.getDepartmentProperty());
            if(dto.getDepartmentType()!=null) wrapper.eq("department_type",dto.getDepartmentType());
            if(dto.getIsCourts()!=null) wrapper.eq("is_courts",dto.getIsCourts());
            sysDepartmentInformationList = sysDepartmentInformationService.list(wrapper);
        }
        List<SysDepartment> hospitalList = sysDepartmentService.list(new QueryWrapper<SysDepartment>()//
                .lambda()//
                .likeRight(SysDepartment::getTreeCode, department.getTreeCode())//
                .in(sysDepartmentInformationList.size()>0,SysDepartment::getId, sysDepartmentInformationList.stream().map(SysDepartmentInformation::getDepartmentId).collect(Collectors.toList()))//
                .eq(SysDepartment::getOrgType, DepartmentEnum.OrgTypeEnum.HOSPITAL.getType()));//
        if (CollectionUtils.isEmpty(hospitalList)) {
            return vo;
        }
        List<MwWarningRecord> mwWarningRecords = new ArrayList<>();
        mwWarningRecords = warningRecordService.list(new QueryWrapper<MwWarningRecord>().lambda()//
                .in(MwWarningRecord::getHospitalId, hospitalList.stream().map(SysDepartment::getId).collect(Collectors.toList()))//
                .between(dto.getStartTime()!=null && dto.getStartTime()!=null,MwWarningRecord::getCreateTime, DateUtil.format(dto.getStartTime(), "yyyy-MM-dd HH:mm:ss"), DateUtil.format(dto.getEndTime(), "yyyy-MM-dd HH:mm:ss"))//
                .between(dto.getRelieveStartTime()!=null && dto.getRelieveStartTime()!=null,MwWarningRecord::getRelieveTime, DateUtil.format(dto.getRelieveStartTime(), "yyyy-MM-dd HH:mm:ss"), DateUtil.format(dto.getRelieveEndTime(), "yyyy-MM-dd HH:mm:ss"))//
        );
        Map<Integer, List<MwWarningRecord>> mwCollectRecordMap = mwWarningRecords.stream().collect(Collectors.groupingBy(MwWarningRecord::getHospitalId));
        List<CollectionWarningLevelItemVO> voList = new ArrayList<>();
        for (SysDepartment sysDepartment : hospitalList) {
            CollectionWarningLevelItemVO itemVO = new CollectionWarningLevelItemVO();
            itemVO.setKey(sysDepartment.getId());
            itemVO.setName(sysDepartment.getDepartName());
            itemVO.setData(new ArrayList<>());
            List<MwWarningRecord> tempList = mwCollectRecordMap.getOrDefault(sysDepartment.getId(), new ArrayList<>());
            voList.add(getLevelVoList(tempList,itemVO,dto.getWarningStatisticalType()));

        }
        //合计
        CollectionWarningLevelItemVO totalItemVO = new CollectionWarningLevelItemVO();
        totalItemVO.setKey(-2);
        totalItemVO.setName("合计");
        totalItemVO.setData(new ArrayList<>());
        voList.add(0,getLevelVoList(mwWarningRecords,totalItemVO,dto.getWarningStatisticalType()));
        vo.setList(voList);
        return vo;
    }

    /**
     * 导出报表
     *
     * @param dto  1区域产废统计 2医院产废统计
     * @param type 1：统计，2：报表
     *
     */
    public void exportDepartmentReport(HttpServletResponse response, CollectRecordSummaryDTO dto,Integer type) throws IOException {

        String fileName = "";
        ExcelWriter writer = null;
        if(type==1){
            switch (dto.getStyleTpl()) {
                case 1:
                    fileName = "区域产废统计";
                    writer = new ExcelWriter(exportDepartmentReport(dto, fileName,type), fileName);
                    break;
                case 2:
                    fileName = "医院产废统计";
                    writer = new ExcelWriter(exportDepartmentReport(dto, fileName,type), fileName);
                    break;
                default:
                    throw new BusinessException(ErrorCode.ERR_500, "请选择报表类型");
            }
        }else {
            switch (dto.getStyleTpl()) {
                case 1:
                    fileName = "区域产废报表";
                    writer = new ExcelWriter(exportDepartmentReport(dto, fileName,type), fileName);
                    break;
                case 2:
                    fileName = "医院产废报表";
                    writer = new ExcelWriter(exportDepartmentReport(dto, fileName,type), fileName);
                    break;
                default:
                    throw new BusinessException(ErrorCode.ERR_500, "请选择报表类型");
            }
        }

        if (writer != null) {
            response.setContentType("application/octet-stream;charset=utf-8");
            response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(fileName, "UTF-8") + ".xlsx");
            writer.flush(response.getOutputStream(), true);
            writer.close();
        }
    }

    /**
     * 预警级别报表(区域)
     *
     * @param dto
     * @return
     */
    public CollectionWarningLevelReportVO getWarningRegionLevelStatementList(CollectionWarningLevelDTO dto) {
        SysDepartment department = sysDepartmentService.getById(dto.getDepartmentId());
        if (department == null) {
            throw new BusinessException(ErrorCode.ERR_500, "区域不存在");
        }
        if (!department.getOrgType().equals(DepartmentEnum.OrgTypeEnum.AREA.getType())) {
            throw new BusinessException(ErrorCode.ERR_500, "区域不存在");
        }
        CollectionWarningLevelReportVO vo = new CollectionWarningLevelReportVO();
        vo.setDepartmentName(department.getDepartName());
        if(dto.getWarningStatisticalType()!=null && dto.getWarningStatisticalType()==2){
            vo.setLegend(Arrays.asList("未出医废预警","入库超时预警","入库前疑似遗失预警","出库超时预警","入库后疑似遗失预警","小计"));
        }else {
            vo.setLegend(Arrays.asList("一级预警","二级预警","三级预警","小计"));
        }
        //
        List<SysDepartment> regionList = sysDepartmentService.list(new QueryWrapper<SysDepartment>()//
                .lambda()//
                .eq(SysDepartment::getParentId, department.getId())//
                .eq(SysDepartment::getOrgType, DepartmentEnum.OrgTypeEnum.AREA.getType()));//
        if (CollectionUtils.isEmpty(regionList)) {
            return vo;
        }

        List<SysDepartmentInformation> sysDepartmentInformationList = new ArrayList<>();
        //if(dto.getDepartmentLevel()!=null || dto.getDepartmentProperty()!=null || dto.getDepartmentType()!=null || dto.getIsCourts()!=null){
            QueryWrapper<SysDepartmentInformation> wrapper = new QueryWrapper<SysDepartmentInformation>();
            wrapper.lambda();
            if(dto.getDepartmentLevel()!=null) wrapper.eq("department_level",dto.getDepartmentLevel());
            if(dto.getDepartmentProperty()!=null) wrapper.eq("department_property",dto.getDepartmentProperty());
            if(dto.getDepartmentType()!=null) wrapper.eq("department_type",dto.getDepartmentType());
            if(dto.getIsCourts()!=null) wrapper.eq("is_courts",dto.getIsCourts());
            sysDepartmentInformationList = sysDepartmentInformationService.list(wrapper);
        //}
        List<MwWarningRecord> totalMwCollectRecordList = new ArrayList<>();
        List<SysDepartment> childrenListAll = new ArrayList<>();
        for (SysDepartment sysDepartment : regionList) {
            List<SysDepartment> childrenList = null;
            if(sysDepartmentInformationList.size() > 0) {
                //获取下级组织
                childrenList = sysDepartmentService.list(new QueryWrapper<SysDepartment>().lambda()
                        .likeRight(SysDepartment::getTreeCode, sysDepartment.getTreeCode())
                        .in( SysDepartment::getId, sysDepartmentInformationList.stream().map(SysDepartmentInformation::getDepartmentId).collect(Collectors.toList()))//
                );
            }else {
                //获取下级组织
                childrenList = sysDepartmentService.list(new QueryWrapper<SysDepartment>().lambda()
                        .likeRight(SysDepartment::getTreeCode, sysDepartment.getTreeCode())
                        .in( SysDepartment::getId, sysDepartmentInformationList.add(new SysDepartmentInformation()))//
                );
            }
            childrenListAll = Stream.of(childrenListAll, childrenList)
                    .flatMap(Collection::stream).distinct().collect(Collectors.toList());
        }
        List<MwWarningRecord> mwWarningRecords = new ArrayList<>();
        if (CollectionUtils.isNotEmpty(childrenListAll)) {
            mwWarningRecords = warningRecordService.list(new QueryWrapper<MwWarningRecord>().lambda()//
                    .in(MwWarningRecord::getHospitalId, childrenListAll.stream().map(SysDepartment::getId).collect(Collectors.toList()))//
                    .between(dto.getStartTime()!=null && dto.getStartTime()!=null,MwWarningRecord::getCreateTime, DateUtil.format(dto.getStartTime(), "yyyy-MM-dd HH:mm:ss"), DateUtil.format(dto.getEndTime(), "yyyy-MM-dd HH:mm:ss"))//
                    .between(dto.getRelieveStartTime()!=null && dto.getRelieveStartTime()!=null,MwWarningRecord::getRelieveTime, DateUtil.format(dto.getRelieveStartTime(), "yyyy-MM-dd HH:mm:ss"), DateUtil.format(dto.getRelieveEndTime(), "yyyy-MM-dd HH:mm:ss"))//
            );
            totalMwCollectRecordList.addAll(mwWarningRecords);
        }
        //合计
        vo.setList(getStatementVoList(totalMwCollectRecordList,dto.getWarningStatisticalType(),dto));
        return vo;
    }
    //预警报表
    private List<CollectionWarningLevelItemVO> getStatementVoList(List<MwWarningRecord> totalMwCollectRecordList,
                                                            Integer warningStatisticalType,
                                                            CollectionWarningLevelDTO dto
    ){
        List<CollectionWarningLevelItemVO> voList =  new ArrayList<>();
        List<Integer> legend = new ArrayList<>();
        if (warningStatisticalType != null && warningStatisticalType == 2) {
            //todo 预警类型
            //1：未出医废预警  3：入库超时预警  5：入库前疑似遗失预警  4：出库超时预警   10：入库后疑似遗失预警
            legend = Arrays.asList(1, 3, 5, 4, 10);
        } else {
            //todo 等级
            legend = Arrays.asList(1, 2, 3);
        }
        //todo 根据日期汇总

        //日期数组
        SimpleDateFormat sdf = new SimpleDateFormat(DEFAULT_PATTERN);
        List<String> dateList = DateUtil.getMonthBetween(sdf.format(dto.getStartTime()),sdf.format(dto.getEndTime()),dto.getStatisticalWayType());
        SimpleDateFormat sdfWayType = new SimpleDateFormat(YYYY_MM_DD);
        if(dto.getStatisticalWayType() == 4){//年
            sdfWayType = new SimpleDateFormat(yyyy);
        }else if(dto.getStatisticalWayType() == 2 || dto.getStatisticalWayType() == 3){//月
            sdfWayType = new SimpleDateFormat(yyyy_MM);
        }
        for(String date : dateList){
            CollectionWarningLevelItemVO  itemVO= new CollectionWarningLevelItemVO();
            itemVO.setKey(null);
            itemVO.setName(null);
            itemVO.setName(date);
            itemVO.setData(new ArrayList<>());
            SimpleDateFormat finalSdfWayType = sdfWayType;
            //总预警数
            BigDecimal warningTotalCount = new BigDecimal(0);
            //总反馈数
            BigDecimal feedbackTotalCount = new BigDecimal(0);
            //总解除数
            BigDecimal relieveTotalCount = new BigDecimal(0);
            for (Integer l : legend) {
                //预警数据
                Long warningCount = 0L;
                if (warningStatisticalType != null && warningStatisticalType == 2) {
                    warningCount = totalMwCollectRecordList.stream().filter(e -> e.getType().equals(l)
                            && finalSdfWayType.format(e.getCreateTime()).equals(date))
                            .count();
                } else {
                    warningCount = totalMwCollectRecordList.stream().filter(e -> e.getLevel().equals(l)
                            && finalSdfWayType.format(e.getCreateTime()).equals(date))
                            .count();
                }
                //反馈数据
                Long feedbackCount = 0L;
                if (warningStatisticalType != null && warningStatisticalType == 2) {
                    feedbackCount = totalMwCollectRecordList.stream().filter(e -> e.getType().equals(l) && e.getMessageCount() > 0
                                    && finalSdfWayType.format(e.getCreateTime()).equals(date))
                            .count();
                } else {
                    feedbackCount = totalMwCollectRecordList.stream().filter(e -> e.getLevel().equals(l) && e.getMessageCount() > 0
                                    && finalSdfWayType.format(e.getCreateTime()).equals(date))
                            .count();
                }

                //解除数
                Long relieveCount = 0L;
                if (warningStatisticalType != null && warningStatisticalType == 2) {
                    relieveCount = totalMwCollectRecordList.stream().filter(e -> e.getType().equals(l) && e.getStatus().equals(MedicalWasteEnum.WarningRecordStatusEnum.PASS)
                                    && finalSdfWayType.format(e.getCreateTime()).equals(date))
                            .count();
                } else {
                    relieveCount = totalMwCollectRecordList.stream().filter(e -> e.getLevel().equals(l) && e.getStatus().equals(MedicalWasteEnum.WarningRecordStatusEnum.PASS)
                                    && finalSdfWayType.format(e.getCreateTime()).equals(date))
                            .count();
                }

                itemVO.getData().add(new BigDecimal(warningCount));
                warningTotalCount = warningTotalCount.add(new BigDecimal(warningCount));
                itemVO.getData().add(new BigDecimal(feedbackCount));
                feedbackTotalCount = feedbackTotalCount.add(new BigDecimal(feedbackCount));

                BigDecimal feedbackPercentage = new BigDecimal(0);
                BigDecimal relievePercentage = new BigDecimal(0);
                if (warningCount > 0) {
                    //反馈率
                    feedbackPercentage = new BigDecimal(feedbackCount).divide(new BigDecimal(warningCount), 4, BigDecimal.ROUND_UP).multiply(BigDecimal.valueOf(100)).setScale(2, BigDecimal.ROUND_UP);
                    //解除率
                    relievePercentage = new BigDecimal(relieveCount).divide(new BigDecimal(warningCount), 4, BigDecimal.ROUND_UP).multiply(BigDecimal.valueOf(100)).setScale(2, BigDecimal.ROUND_UP);
                }
                itemVO.getData().add(feedbackPercentage);
                itemVO.getData().add(new BigDecimal(relieveCount));
                relieveTotalCount = relieveTotalCount.add(new BigDecimal(relieveCount));
                itemVO.getData().add(relievePercentage);
            }
            BigDecimal feedbackTotalPercentage = new BigDecimal(0);
            BigDecimal relieveTotalPercentage = new BigDecimal(0);
            if(warningTotalCount.intValue()>0){
                feedbackTotalPercentage = feedbackTotalCount.divide(warningTotalCount,4,BigDecimal.ROUND_UP).multiply(BigDecimal.valueOf(100)).setScale(2,BigDecimal.ROUND_UP);
                relieveTotalPercentage = relieveTotalCount.divide(warningTotalCount,4,BigDecimal.ROUND_UP).multiply(BigDecimal.valueOf(100)).setScale(2,BigDecimal.ROUND_UP);
            }

            itemVO.getData().add(warningTotalCount);
            itemVO.getData().add(feedbackTotalCount);
            itemVO.getData().add(feedbackTotalPercentage);
            itemVO.getData().add(relieveTotalCount);
            itemVO.getData().add(relieveTotalPercentage);
            voList.add(itemVO);
        }
        //合计
        CollectionWarningLevelItemVO  totalItemVO= new CollectionWarningLevelItemVO();
        totalItemVO.setKey(-2);
        totalItemVO.setName("合计");
        totalItemVO.setData(new ArrayList<>());
        voList.add(0,getLevelVoList(totalMwCollectRecordList,totalItemVO,dto.getWarningStatisticalType()));
        return  voList;
    }

    /**
     * 预警级别统计(医院)
     *
     * @param dto
     * @return
     */
    public CollectionWarningLevelReportVO getWarningHospitalLevelStatementList(CollectionWarningLevelDTO dto) {

        SysDepartment department = sysDepartmentService.getById(dto.getDepartmentId());
        if (department == null) {
            throw new BusinessException(ErrorCode.ERR_500, "区域不存在");
        }
        if (!department.getOrgType().equals(DepartmentEnum.OrgTypeEnum.AREA.getType())) {
            throw new BusinessException(ErrorCode.ERR_500, "区域不存在");
        }
        CollectionWarningLevelReportVO vo = new CollectionWarningLevelReportVO();
        vo.setDepartmentName(department.getDepartName());
        //
        List<SysDepartmentInformation> sysDepartmentInformationList = new ArrayList<>();
        if(dto.getDepartmentLevel()!=null || dto.getDepartmentProperty()!=null || dto.getDepartmentType()!=null || dto.getIsCourts()!=null){
            QueryWrapper<SysDepartmentInformation> wrapper = new QueryWrapper<SysDepartmentInformation>();
            wrapper.lambda();
            if(dto.getDepartmentLevel()!=null) wrapper.eq("department_level",dto.getDepartmentLevel());
            if(dto.getDepartmentProperty()!=null) wrapper.eq("department_property",dto.getDepartmentProperty());
            if(dto.getDepartmentType()!=null) wrapper.eq("department_type",dto.getDepartmentType());
            if(dto.getIsCourts()!=null) wrapper.eq("is_courts",dto.getIsCourts());
            sysDepartmentInformationList = sysDepartmentInformationService.list(wrapper);
        }
        List<SysDepartment> hospitalList = sysDepartmentService.list(new QueryWrapper<SysDepartment>()//
                .lambda()//
                .likeRight(SysDepartment::getTreeCode, department.getTreeCode())//
                .in(sysDepartmentInformationList.size()>0,SysDepartment::getId, sysDepartmentInformationList.stream().map(SysDepartmentInformation::getDepartmentId).collect(Collectors.toList()))//
                .eq(SysDepartment::getOrgType, DepartmentEnum.OrgTypeEnum.HOSPITAL.getType()));//
        if (CollectionUtils.isEmpty(hospitalList)) {
            return vo;
        }
        List<MwWarningRecord> mwWarningRecords = new ArrayList<>();
        mwWarningRecords = warningRecordService.list(new QueryWrapper<MwWarningRecord>().lambda()//
                .in(MwWarningRecord::getHospitalId, hospitalList.stream().map(SysDepartment::getId).collect(Collectors.toList()))//
                .between(dto.getStartTime()!=null && dto.getStartTime()!=null,MwWarningRecord::getCreateTime, DateUtil.format(dto.getStartTime(), "yyyy-MM-dd HH:mm:ss"), DateUtil.format(dto.getEndTime(), "yyyy-MM-dd HH:mm:ss"))//
                .between(dto.getRelieveStartTime()!=null && dto.getRelieveStartTime()!=null,MwWarningRecord::getRelieveTime, DateUtil.format(dto.getRelieveStartTime(), "yyyy-MM-dd HH:mm:ss"), DateUtil.format(dto.getRelieveEndTime(), "yyyy-MM-dd HH:mm:ss"))//
        );
        //合计
        vo.setList(getStatementVoList(mwWarningRecords,dto.getWarningStatisticalType(),dto));
        return vo;
    }

    /**
     *
     * @param dto
     * @param sheetName
     * @param type 1:统计，2:报表
     * @return
     */
    private XSSFWorkbook exportDepartmentReport(CollectRecordSummaryDTO dto,  String sheetName,Integer type) {

        DepartmentReportVO vo = null;

        XSSFWorkbook workbook = new XSSFWorkbook();
        String cellName = "", title = "";
        if (dto.getStyleTpl() == 1) {
            if(type==1){
                vo = getRegionReportList(dto);
                title = vo.getDepartmentName() + "医疗废物统计";
                cellName = "区域名称";
            }else if(type==2){
                vo = getRegionStatementList(dto);
                title = vo.getDepartmentName() + "医疗废物报表";
                cellName = "时间";
            }

        } else if (dto.getStyleTpl() == 2) {
            if(type==1){
                vo = getHospitalReportList(dto);
                title = vo.getDepartmentName() + "医疗废物统计";
                cellName = "医院名称";
            }else if(type==2){
                vo = getHospitalStatementList(dto);
                title = vo.getDepartmentName() + "医疗废物报表";
                cellName = "时间";
            }

        }
        XSSFSheet sheet = workbook.createSheet(sheetName);
        XSSFCellStyle cellStyle = createDefaultCellStyle(workbook);
        XSSFCellStyle rightCellStyle = createDefaultRightCellStyle(workbook);
        //
        int maxCellSize = 1 + vo.getLegend().size() * 2;
        XSSFRow titleRow = sheet.createRow(0);
        XSSFRow dateRow = sheet.createRow(1);
        XSSFRow firstRow = sheet.createRow(2);
        XSSFRow secondRow = sheet.createRow(3);
        int legendIndex = 0;
        for (int i = 0; i < maxCellSize; i++) {
            XSSFCell titleRowCell = titleRow.createCell(i);
            titleRowCell.setCellStyle(cellStyle);
            XSSFCell firstRowCell = firstRow.createCell(i);
            firstRowCell.setCellStyle(cellStyle);
            XSSFCell secondRowCell = secondRow.createCell(i);
            secondRowCell.setCellStyle(cellStyle);
            XSSFCell dateRowCell = dateRow.createCell(i);
            dateRowCell.setCellStyle(rightCellStyle);
            if (i == 0) {
                titleRowCell.setCellValue(title);
                firstRowCell.setCellValue(cellName);
            } else {
                if (i % 2 == 1) {
                    firstRowCell.setCellValue(vo.getLegend().get(legendIndex));
                    legendIndex++;
                    //
                    secondRowCell.setCellValue("数量");
                } else {
                    secondRowCell.setCellValue("重量(KG)");
                }
            }
            if (i == maxCellSize - 1) {
                dto.setStatisticalWayType(dto.getStatisticalWayType()==null?1:dto.getStatisticalWayType());
                if(dto.getStatisticalWayType() == 1 || dto.getStatisticalWayType() == 3){
                    dateRowCell.setCellValue("时间：" + DateUtil.format(dto.getStartTime(), "yyyy年MM月dd日") + "至" + DateUtil.format(dto.getEndTime(), "yyyy年MM月dd日"));
                }else if(dto.getStatisticalWayType() == 2){
                    dateRowCell.setCellValue("时间：" + DateUtil.format(dto.getStartTime(), "yyyy年MM月") + "至" + DateUtil.format(dto.getEndTime(), "yyyy年MM月"));
                }else if(dto.getStatisticalWayType() == 4){
                    dateRowCell.setCellValue("时间：" + DateUtil.format(dto.getStartTime(), "yyyy年") + "至" + DateUtil.format(dto.getEndTime(), "yyyy年"));
                }

            }
        }
        sheet.addMergedRegion(new CellRangeAddress(0, 0, 0, maxCellSize - 1));
        sheet.addMergedRegion(new CellRangeAddress(2, 3, 0, 0));
        for (int i = 0; i < vo.getLegend().size(); i++) {
            sheet.addMergedRegion(new CellRangeAddress(2, 2, 1 + i * 2, 2 + i * 2));
        }
        //
        if (CollectionUtils.isNotEmpty(vo.getList())) {
            for (int i = 0; i < vo.getList().size(); i++) {
                DepartmentReportItemVO itemVO = vo.getList().get(i);
                XSSFRow dataRow = sheet.createRow(i + 4);
                int dataIndex = 0;
                for (int k = 0; k < maxCellSize; k++) {
                    XSSFCell dataRowCell = dataRow.createCell(k);
                    dataRowCell.setCellStyle(cellStyle);
                    if (k == 0) {
                        dataRowCell.setCellValue(itemVO.getName());
                    } else {
                        dataRowCell.setCellValue(itemVO.getData().get(dataIndex).toString());
                        dataIndex++;
                    }
                }
            }
        }
        sheet.setColumnWidth(0, 6065);
        return workbook;
    }


    /**
     * 导出报表
     *
     * @param dto  1区域预警级别统计 2医院预警级别统计
     * @param type 1:统计，2:报表
     */
    public void exportCollectionWarningLevelReport(HttpServletResponse response, CollectionWarningLevelDTO dto,Integer type) throws IOException {

        String fileName = "";
        ExcelWriter writer = null;
        if(type == 1 ){
            switch (dto.getStyleTpl()) {
                case 1:
                    fileName = "区域预警级别统计";
                    if(dto.getWarningStatisticalType()!=null && dto.getWarningStatisticalType() == 2){
                        fileName = "区域预警类型统计";
                    }
                    writer = new ExcelWriter(exportCollectionWarningLevelReport(dto, fileName,type), fileName);
                    break;
                case 2:
                    fileName = "医院预警级别统计";
                    if(dto.getWarningStatisticalType()!=null && dto.getWarningStatisticalType() == 2){
                        fileName = "医院预警类型统计";
                    }
                    writer = new ExcelWriter(exportCollectionWarningLevelReport(dto, fileName,type), fileName);
                    break;
                default:
                    throw new BusinessException(ErrorCode.ERR_500, "请选择报表类型");
            }
        }else {
            fileName = "预警级别报表";
            if(dto.getWarningStatisticalType()!=null && dto.getWarningStatisticalType() == 2){
                fileName = "预警类型报表";
            }
            writer = new ExcelWriter(exportCollectionWarningLevelReport(dto, fileName,type), fileName);
        }

        if (writer != null) {
            response.setContentType("application/octet-stream;charset=utf-8");
            response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(fileName, "UTF-8") + ".xlsx");
            writer.flush(response.getOutputStream(), true);
            writer.close();
        }
    }

    private XSSFWorkbook exportCollectionWarningLevelReport(CollectionWarningLevelDTO dto,  String sheetName,Integer type) {

        CollectionWarningLevelReportVO vo = null;

        XSSFWorkbook workbook = new XSSFWorkbook();
        String cellName = "", title = "";
        if (dto.getStyleTpl() == 1) {
            if(type==1){//统计
                vo = getWarningRegionLevelReportList(dto);
                cellName = "区域名称";
            }else if(type==2){//报表
                vo = getWarningRegionLevelStatementList(dto);
                cellName = "时间";
            }


        } else if (dto.getStyleTpl() == 2) {
            if(type==1){//统计
                vo = getWarningHospitalLevelReportList(dto);
                cellName = "医院名称";
            }else if(type==2){//报表
                vo = getWarningHospitalLevelStatementList(dto);
                cellName = "时间";
            }


        }
        if(type==1){
            if(dto.getWarningStatisticalType()!=null && dto.getWarningStatisticalType()==2){
                title = vo.getDepartmentName() + "预警类型统计";
            }else{
                title = vo.getDepartmentName() + "预警级别统计";
            }
        }else {
            if(dto.getWarningStatisticalType()!=null && dto.getWarningStatisticalType()==2){
                title = vo.getDepartmentName() + "预警类型报表";
            }else{
                title = vo.getDepartmentName() + "预警级别报表";
            }
        }
        XSSFSheet sheet = workbook.createSheet(sheetName);
        XSSFCellStyle cellStyle = createDefaultCellStyle(workbook);
        XSSFCellStyle rightCellStyle = createDefaultRightCellStyle(workbook);
        //
        int maxCellSize = 21;
        if(dto.getWarningStatisticalType()!=null && dto.getWarningStatisticalType()==2){
            maxCellSize = 31;
        }
        XSSFRow titleRow = sheet.createRow(0);
        XSSFRow dateRow = sheet.createRow(1);
        XSSFRow firstRow = sheet.createRow(2);
        XSSFRow secondRow = sheet.createRow(3);
        for (int i = 0; i < maxCellSize; i++) {
            XSSFCell titleRowCell = titleRow.createCell(i);
            titleRowCell.setCellStyle(cellStyle);
            XSSFCell firstRowCell = firstRow.createCell(i);
            firstRowCell.setCellStyle(cellStyle);
            XSSFCell secondRowCell = secondRow.createCell(i);
            secondRowCell.setCellStyle(cellStyle);
            XSSFCell dateRowCell = dateRow.createCell(i);
            dateRowCell.setCellStyle(rightCellStyle);
            if (i == 0) {
                titleRowCell.setCellValue(title);
                firstRowCell.setCellValue(cellName);
            } else {
                if(i==1){//
                    firstRowCell.setCellValue("一级预警");
                    if(dto.getWarningStatisticalType()!=null && dto.getWarningStatisticalType()==2){
                        firstRowCell.setCellValue("未出医废预警");
                    }
                    secondRowCell.setCellValue("预警数");
                }
                if(i==6){//
                    firstRowCell.setCellValue("二级预警");
                    if(dto.getWarningStatisticalType()!=null && dto.getWarningStatisticalType()==2){
                        firstRowCell.setCellValue("入库超时预警");
                    }
                    secondRowCell.setCellValue("预警数");
                }
                if(i==11){//
                    firstRowCell.setCellValue("三级预警");
                    if(dto.getWarningStatisticalType()!=null && dto.getWarningStatisticalType()==2){
                        firstRowCell.setCellValue("入库前疑似遗失预警");
                    }
                    secondRowCell.setCellValue("预警数");
                }
                if(dto.getWarningStatisticalType()!=null && dto.getWarningStatisticalType()==2){
                    if (i == 16) {//
                        firstRowCell.setCellValue("出库超时预警");
                        secondRowCell.setCellValue("预警数");
                    }
                    if (i == 21) {//
                        firstRowCell.setCellValue("入库后疑似遗失预警");
                        secondRowCell.setCellValue("预警数");
                    }
                    if (i == 26) {//
                        firstRowCell.setCellValue("小计");
                        secondRowCell.setCellValue("预警数");
                    }
                }else {
                    if (i == 16) {//
                        firstRowCell.setCellValue("小计");
                        secondRowCell.setCellValue("预警数");
                    }

                }

                if(i==2 || i==7 || i==12 || i==17 || i==22 || i==27){
                    secondRowCell.setCellValue("反馈数");
                }
                if(i==3 || i==8 || i==13 || i==18 || i==23 || i==28){
                    secondRowCell.setCellValue("反馈率");
                }
                if(i==4 || i==9 || i==14 || i==19 || i==24 || i==29){
                    secondRowCell.setCellValue("解除数");
                }
                if(i==5 || i==10 || i==15 || i==20 || i==25 || i==30){
                    secondRowCell.setCellValue("解除率");
                }
            }
            if (i == maxCellSize - 1) {
                dto.setStatisticalWayType(dto.getStatisticalWayType()==null?1:dto.getStatisticalWayType());
                if(dto.getStatisticalWayType() == 1 || dto.getStatisticalWayType() == 3){
                    dateRowCell.setCellValue("时间：" + DateUtil.format(dto.getStartTime(), "yyyy年MM月dd日") + "至" + DateUtil.format(dto.getEndTime(), "yyyy年MM月dd日"));
                }else if(dto.getStatisticalWayType() == 2){
                    dateRowCell.setCellValue("时间：" + DateUtil.format(dto.getStartTime(), "yyyy年MM月") + "至" + DateUtil.format(dto.getEndTime(), "yyyy年MM月"));
                }else if(dto.getStatisticalWayType() == 4){
                    dateRowCell.setCellValue("时间：" + DateUtil.format(dto.getStartTime(), "yyyy年") + "至" + DateUtil.format(dto.getEndTime(), "yyyy年"));
                }

            }
        }
        sheet.addMergedRegion(new CellRangeAddress(0, 0, 0, maxCellSize - 1));
        sheet.addMergedRegion(new CellRangeAddress(2, 3, 0, 0));
        sheet.addMergedRegion(new CellRangeAddress(2, 2, 1, 5));
        sheet.addMergedRegion(new CellRangeAddress(2, 2, 6, 10));
        sheet.addMergedRegion(new CellRangeAddress(2, 2, 11, 15));
        sheet.addMergedRegion(new CellRangeAddress(2, 2, 16, 20));
        if(dto.getWarningStatisticalType()!=null && dto.getWarningStatisticalType()==2){
            sheet.addMergedRegion(new CellRangeAddress(2, 2, 21, 25));
            sheet.addMergedRegion(new CellRangeAddress(2, 2, 26, 30));
        }

        //
        if (CollectionUtils.isNotEmpty(vo.getList())) {
            for (int i = 0; i < vo.getList().size(); i++) {
                CollectionWarningLevelItemVO itemVO = vo.getList().get(i);
                XSSFRow dataRow = sheet.createRow(i + 4);
                int dataIndex = 0;
                for (int k = 0; k < maxCellSize; k++) {
                    XSSFCell dataRowCell = dataRow.createCell(k);
                    dataRowCell.setCellStyle(cellStyle);
                    if (k == 0) {
                        dataRowCell.setCellValue(itemVO.getName());
                    } else {
                        dataRowCell.setCellValue(itemVO.getData().get(dataIndex).toString());
                        if(k ==3 || k ==5 || k ==8 || k ==10 || k ==13 || k ==15 || k==18
                                || k==20 || k==23 || k==25 || k==28 || k==30){
                            dataRowCell.setCellValue(itemVO.getData().get(dataIndex).toString()+"%");
                        }
                        dataIndex++;
                    }
                }
            }
        }
        sheet.setColumnWidth(0, 6065);
        return workbook;
    }

    private XSSFWorkbook exportHospitalReport(MedicalReportDTO dto, String sheetName) {

        MedicalReportVO vo = getMedicalReportList(dto);
        XSSFWorkbook workbook = new XSSFWorkbook();
        XSSFSheet sheet = workbook.createSheet(sheetName);
        XSSFCellStyle cellStyle = createDefaultCellStyle(workbook);
        XSSFCellStyle rightCellStyle = createDefaultRightCellStyle(workbook);
        int maxCellSize = 6 + vo.getLegend().size() ;
        XSSFRow titleRow = sheet.createRow(0);
        XSSFRow firstRow = sheet.createRow(1);
        XSSFRow secondRow = sheet.createRow(2);
        int legendIndex = 0;
        int titleIndex = 0;
        for (int i = 0; i < maxCellSize; i++) {
            XSSFCell titleRowCell = titleRow.createCell(i);
            titleRowCell.setCellStyle(cellStyle);
            XSSFCell firstRowCell = firstRow.createCell(i);
            firstRowCell.setCellStyle(cellStyle);
            XSSFCell secondRowCell = secondRow.createCell(i);
            secondRowCell.setCellStyle(cellStyle);
            if (i == 0) {
                titleRowCell.setCellValue("医疗机构统计");
                firstRowCell.setCellValue("机构名称");
            } else {
                String[] titleStr = new String[]{"机构级别","机构类型","机构性质","分院"};
                if(i<5) {
                    firstRowCell.setCellValue(titleStr[titleIndex]);
                    titleIndex++;
                }
                if(i>=5 && i<= maxCellSize - 2){
                    firstRowCell.setCellValue("科室总数");
                }
                if (i>= 5 && i<=maxCellSize - 2) {
                    secondRowCell.setCellValue(vo.getLegend().stream().toArray()[legendIndex].toString());
                    legendIndex++;
                }
                if (i == maxCellSize - 1) {
                    firstRowCell.setCellValue("创建时间");
                }
            }
        }
        sheet.addMergedRegion(new CellRangeAddress(0, 0, 0, maxCellSize - 1));
        sheet.addMergedRegion(new CellRangeAddress(1, 2, 0, 0));
        sheet.addMergedRegion(new CellRangeAddress(1, 2, 1, 1));
        sheet.addMergedRegion(new CellRangeAddress(1, 2, 2, 2));
        sheet.addMergedRegion(new CellRangeAddress(1, 2, 3, 3));
        sheet.addMergedRegion(new CellRangeAddress(1, 2, 4, 4));
        sheet.addMergedRegion(new CellRangeAddress(1, 1, 5, maxCellSize - 2));
        sheet.addMergedRegion(new CellRangeAddress(1, 2, maxCellSize - 1, maxCellSize - 1));
        //
        if (CollectionUtils.isNotEmpty(vo.getList())) {
            for (int i = 0; i < vo.getList().size(); i++) {
                SysDepartmentInformationReportVO itemVO = vo.getList().get(i);
                XSSFRow dataRow = sheet.createRow(i + 3);
                int dataIndex = 0;
                for (int k = 0; k < maxCellSize; k++) {
                    XSSFCell dataRowCell = dataRow.createCell(k);
                    dataRowCell.setCellStyle(cellStyle);
                    if (k == 0) {
                        dataRowCell.setCellValue(itemVO.getDepartmentName());
                    }else if (k == 1) {
                        dataRowCell.setCellValue(itemVO.getDepartmentLevel());
                    }else if (k == 2) {
                        dataRowCell.setCellValue(itemVO.getDepartmentType());
                    }else if (k == 3) {
                        dataRowCell.setCellValue(itemVO.getDepartmentProperty());
                    }else if (k == 4) {
                        if(itemVO.getIsCourts()!=null){
                            if(itemVO.getIsCourts()==0){
                                dataRowCell.setCellValue("否");
                            }else {
                                dataRowCell.setCellValue("是");
                            }
                        }
                    } else if(k == maxCellSize - 1){
                        dataRowCell.setCellValue(DateUtil.format(itemVO.getCreateTime(),"yyyy-MM-dd"));
                    }else {
                        dataRowCell.setCellValue(itemVO.getData()[dataIndex]);
                        dataIndex++;
                    }
                }
            }
        }
        sheet.setColumnWidth(0, 6065);


        return workbook;
    }

    private XSSFWorkbook exportCollectionAmendant(ReportCollectionAmendantDTO dto, String sheetName) {

        DepartmentCollectionAmendantReportVO vo = getCollectionAmendantRecordReportList(dto);
        XSSFWorkbook workbook = new XSSFWorkbook();
        XSSFSheet sheet = workbook.createSheet(sheetName);
        XSSFCellStyle cellStyle = createDefaultCellStyle(workbook);
        XSSFCellStyle leftCellStyle = createDefaultLeftCellStyle(workbook);
        XSSFCellStyle rightCellStyle = createDefaultRightCellStyle(workbook);
        //
        int maxCellSize = 12;
        XSSFRow titleRow = sheet.createRow(0);
        XSSFRow headFirstRow = sheet.createRow(1);
        XSSFRow headSecondRow = sheet.createRow(2);
        int legendIndex = 0;
        for (int i = 0; i < maxCellSize; i++) {
            XSSFCell titleRowCell = titleRow.createCell(i);
            titleRowCell.setCellStyle(cellStyle);
            XSSFCell headFirstRowwCell = headFirstRow.createCell(i);
            headFirstRowwCell.setCellStyle(cellStyle);
            XSSFCell headSecondRowCell = headSecondRow.createCell(i);
            headSecondRowCell.setCellStyle(cellStyle);
            if (i == 0) {
                titleRowCell.setCellValue("数据修改统计");
                headFirstRowwCell.setCellValue("机构名称");
            } else if (i == 1) {
                headFirstRowwCell.setCellValue("医废总数");
            } else if (i == 2) {
                headFirstRowwCell.setCellValue("医废补录");
                headSecondRowCell.setCellValue("数量");
            } else if (i == 3) {
                headSecondRowCell.setCellValue("补录率");
            }else if (i == 4) {
                headFirstRowwCell.setCellValue("修改医废类别");
                headSecondRowCell.setCellValue("数量");
            } else if (i == 5) {
                headSecondRowCell.setCellValue("修改率");
            }else if (i == 6) {
                headFirstRowwCell.setCellValue("修改重量");
                headSecondRowCell.setCellValue("数量");
            } else if (i == 7) {
                headSecondRowCell.setCellValue("修改率");
            }else if (i == 8) {
                headFirstRowwCell.setCellValue("删除");
                headSecondRowCell.setCellValue("数量");
            } else if (i == 9) {
                headSecondRowCell.setCellValue("删除率");
            }else if (i == 10) {
                headFirstRowwCell.setCellValue("小计");
                headSecondRowCell.setCellValue("数量");
            } else if (i == 11) {
                headSecondRowCell.setCellValue("修改率");
            }
        }
        sheet.addMergedRegion(new CellRangeAddress(0, 0, 0, maxCellSize - 1));
        //
        sheet.addMergedRegion(new CellRangeAddress(1, 2, 0, 0));
        sheet.addMergedRegion(new CellRangeAddress(1, 2, 1, 1));
        sheet.addMergedRegion(new CellRangeAddress(1, 1, 2, 3));
        sheet.addMergedRegion(new CellRangeAddress(1, 1, 4, 5));
        sheet.addMergedRegion(new CellRangeAddress(1, 1, 6, 7));
        sheet.addMergedRegion(new CellRangeAddress(1, 1, 8, 9));
        sheet.addMergedRegion(new CellRangeAddress(1, 1, 10, 11));
        //
        if (CollectionUtils.isNotEmpty(vo.getList())) {
            for (int i = 0; i < vo.getList().size(); i++) {
                DepartmentReportItemVO itemVO = vo.getList().get(i);
                XSSFRow dataRow = sheet.createRow(i + 3);
                int dataIndex = 0;
                for (int k = 0; k < maxCellSize; k++) {
                    XSSFCell dataRowCell = dataRow.createCell(k);
                    dataRowCell.setCellStyle(cellStyle);
                    if (k == 0) {
                        dataRowCell.setCellValue(itemVO.getName());
                    } else {
                        dataRowCell.setCellValue(itemVO.getData().get(dataIndex).toString());
                        if(k==3 || k==5 || k==7 || k==9 || k==11){
                            dataRowCell.setCellValue(itemVO.getData().get(dataIndex).toString()+"%");
                        }
                        dataIndex++;
                    }
                }
            }
        }
        sheet.setColumnWidth(0, 6065);
        return workbook;
    }

    private XSSFCellStyle createDefaultCellStyle(XSSFWorkbook workbook) {

        XSSFCellStyle cellStyle = workbook.createCellStyle();
        cellStyle.setVerticalAlignment(VerticalAlignment.CENTER);
        cellStyle.setAlignment(HorizontalAlignment.CENTER);
        XSSFFont font = workbook.createFont();
        font.setFontName("宋体");
        font.setFontHeightInPoints((short) 12);
        cellStyle.setFont(font);
        return cellStyle;
    }

    private XSSFCellStyle createDefaultLeftCellStyle(XSSFWorkbook workbook) {

        XSSFCellStyle cellStyle = workbook.createCellStyle();
        cellStyle.setVerticalAlignment(VerticalAlignment.CENTER);
        cellStyle.setAlignment(HorizontalAlignment.LEFT);
        XSSFFont font = workbook.createFont();
        font.setFontName("宋体");
        font.setFontHeightInPoints((short) 12);
        cellStyle.setFont(font);
        return cellStyle;
    }

    private XSSFCellStyle createDefaultRightCellStyle(XSSFWorkbook workbook) {

        XSSFCellStyle cellStyle = workbook.createCellStyle();
        cellStyle.setVerticalAlignment(VerticalAlignment.CENTER);
        cellStyle.setAlignment(HorizontalAlignment.RIGHT);
        XSSFFont font = workbook.createFont();
        font.setFontName("宋体");
        font.setFontHeightInPoints((short) 12);
        cellStyle.setFont(font);
        return cellStyle;
    }
}