package com.poteviohealth.cgp.statistics.service.impl;

import cn.hutool.core.date.DateUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.google.common.collect.Lists;
import com.google.common.collect.Maps;
import com.poteviohealth.cgp.common.filter.TokenContext;
import com.poteviohealth.cgp.common.integrated.DateParams;
import com.poteviohealth.cgp.common.integrated.ListParams;
import com.poteviohealth.cgp.common.integrated.customer.model.CustomerServiceParams;
import com.poteviohealth.cgp.common.integrated.customer.model.CustomerSubsidyDTO;
import com.poteviohealth.cgp.common.integrated.customer.model.SubsidyCustomerFace;
import com.poteviohealth.cgp.common.integrated.customer.model.SubsidyCustomerJsonFace;
import com.poteviohealth.cgp.common.integrated.finance.model.MemberListData;
import com.poteviohealth.cgp.common.integrated.finance.model.MonthData;
import com.poteviohealth.cgp.common.integrated.order.model.OrderStatisticsData;
import com.poteviohealth.cgp.common.integrated.partner.model.AreaDTO;
import com.poteviohealth.cgp.common.integrated.partner.model.EmployeeStationFace;
import com.poteviohealth.cgp.common.integrated.partner.model.EmployeeStationJsonFace;
import com.poteviohealth.cgp.common.service.impl.BaseServiceImpl;
import com.poteviohealth.cgp.statistics.mapper.OrderMapper;
import com.poteviohealth.cgp.statistics.model.Order;
import com.poteviohealth.cgp.statistics.model.indto.DishesOrderWebInDTO;
import com.poteviohealth.cgp.statistics.model.indto.OrderCostWebInDTO;
import com.poteviohealth.cgp.statistics.model.indto.OrderServiceWebInDTO;
import com.poteviohealth.cgp.statistics.model.outdto.*;
import com.poteviohealth.cgp.statistics.service.IOrderService;
import com.poteviohealth.cgp.statistics.utils.CostOrderExcelTask;
import com.poteviohealth.cgp.statistics.utils.DishesOrderExcelTask;
import com.poteviohealth.cgp.statistics.utils.OrderExcelTask;
import lombok.extern.log4j.Log4j2;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.lang3.time.DateUtils;
import org.apache.ibatis.builder.BuilderException;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

import java.math.BigDecimal;
import java.text.DecimalFormat;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;

/**
 * 居家大屏
 * @author Qin
 */
@Service
@Log4j2
public class OrderServiceImpl extends BaseServiceImpl<OrderMapper, Order> implements IOrderService {

    @Value("${sync.dbName}")
    private String dbName;
    @Override
    public void statisticsOrder(String dateTime){
        try {
            TokenContext.setOperator(1);
            //检查区域,没有的新增
            List<Order> list = this.list();
            Date date = new Date();
            if(StringUtils.isNotEmpty(dateTime)){
                date = DateUtils.parseDate(dateTime,"yyyy-MM-dd HH:mm:ss");
            }

            List<AreaDTO> areaList = baseMapper.areaList(dbName);
            if(list.size() != areaList.size()){
                List<Integer> ids = Lists.newArrayList();
                List<Order> newOrderList = Lists.newArrayList();
                if(list.size()>0){
                    ids = list.stream().map(o->o.getAreaId()).collect(Collectors.toList());
                }
                for (AreaDTO areaDTO : areaList) {
                    if(!ids.contains(areaDTO.getId())){
                        Order order = new Order();
                        order.setOperatorId(1);
                        order.setAreaId(areaDTO.getId());
                        order.setAreaName(areaDTO.getName());
                        order.setTreePath(areaDTO.getTreePath());
                        order.setSourceLevel(areaDTO.getLevel());
                        Integer size = 0;
                       switch (order.getSourceLevel()){
                           case 1:
                               size =4;
                               break;
                           case 2:
                               size =6;
                               break;
                           case 3:
                               size =9;
                               break;
                       }
                       if(StringUtils.isNotBlank(areaDTO.getRegionAreaCode())){
                           order.setRegionAreaCode(areaDTO.getRegionAreaCode().substring(0,size));
                       }

                        newOrderList.add(order);
                    }
                }
                this.saveBatch(newOrderList);
                list = this.list();
            }
            Map<Integer,List<Order>> maps = list.stream().collect(Collectors.groupingBy(Order::getAreaId));

            if(!maps.isEmpty()){
                log.info("---数据清零开始---");
                changeZero(maps,date);
                log.info("---数据清零结束---");
                Date startDate = null;
                for (Integer integer : maps.keySet()) {
                    startDate = maps.get(integer).get(0).getChangeDate();
                    break;
                }

                DateParams dateParams = new DateParams();
                dateParams.setStartDate(startDate);
                dateParams.setEndDate(date);
                //更新服务人员数据
                log.info("---更新服务人员数据开始---");
                changeEmployee(maps);
                log.info("---更新服务人员数据结束---");
                List<Integer> operatorIds = baseMapper.getOperatorList(dbName);
                log.info("---获取客户数据开始---");
                List<CustomerSubsidyDTO> customerList = this.getSubsidyCustomerList(dateParams,operatorIds);
                log.info("---获取客户数据结束---");
                //更新客户数据
                if(!customerList.isEmpty()){
                    log.info("---更新客户数据开始---");
                    changeCustomer(maps,customerList,operatorIds);
                    log.info("---更新客户数据结束---");
                }
                //获取助餐服务客户数
                List<ListParams> mealList = this.getSubsidyCustomerMealList(dateParams,operatorIds);
                if(CollectionUtils.isNotEmpty(mealList)){
                    for (Integer integer : maps.keySet()) {
                        for (ListParams params : mealList) {
                            if(params.getId().equals(integer)){
                                for (Order order : maps.get(integer)) {
                                    order.setServiceCustomerNum(order.getServiceCustomerNum()+params.getKey());
                                }
                            }
                        }
                    }
                }
                //更新工单相关数据
                log.info("---更新工单数据开始---");
                List<ListParams> categoryList = baseMapper.getAllCategory(dbName);
                changeOrder(maps,dateParams,operatorIds,categoryList);
                log.info("---更新工单数据结束---");
                //更新积分相关数据
                log.info("---更新商户积分数据开始---");
                changeIntegral(maps,operatorIds,categoryList);
                log.info("---更新商户积分数据结束---");

                log.info("---客户积分开始获取---");
                changeCustomerIntegral(maps,dateParams);
                log.info("---客户积分结束获取---");
                log.info("---积分流水开始获取---");
                changeTransIntegral(maps,dateParams);
                log.info("---积分流水结束获取---");
                for (Integer integer : maps.keySet()) {
                    for (Order order : maps.get(integer)) {
                        order.setChangeDate(date);
                    }
                }
                this.saveOrUpdateBatch(list);
            }
            log.info("完成----");
        }catch (Exception e){
            e.printStackTrace();
        }

    }

    @Override
    public List<OrderExcelDTO> orderExcel(OrderServiceWebInDTO dto) {
        Integer operatorId = TokenContext.cureOperatorId();
        QueryWrapper queryWrapper = orderServiceQuery(dto, "o.");
        int count;
        if (null != dto.getProductIds()) {
            queryWrapper.eq("od.product_id", dto.getProductIds());
            count = baseMapper.orderPageListAllSize(queryWrapper,dbName,operatorId);
        }else{
            QueryWrapper<Order> queryWrapper2 = orderServiceQuery(dto, "o.");
            count = baseMapper.orderPageListSize(queryWrapper2,dbName,operatorId);
        }
        //每页1000条,计算总页数
        int maxPage = (int) Math.ceil(count/10000.0);
        List<OrderExcelDTO> list = Lists.newArrayList();
        ForkJoinPool pool = new ForkJoinPool();
        try {
            OrderExcelTask task = new OrderExcelTask(1,maxPage, JSONObject.toJSONString(queryWrapper), operatorId, dbName,baseMapper);
            Future<List<OrderExcelDTO>> future = pool.submit(task);
                do {
                   pool.awaitTermination(1, TimeUnit.SECONDS);
                } while (!future.isDone());
                pool.shutdown();
                list = future.get();
        }catch (Exception e){
            e.printStackTrace();
            throw new BuilderException("工单导出失败,请重新操作");
        }

        return list;
    }

    @Override
    public List<DishesOrderWebOutDTO> orderDishes(DishesOrderWebInDTO dto) {
        Integer operatorId = TokenContext.cureOperatorId();
        QueryWrapper queryWrapper = webQuery(dto);
        int count = baseMapper.dishesOrderPageListAllSize(queryWrapper,dbName,operatorId);
        //每页1000条,计算总页数
        int maxPage = (int) Math.ceil(count/10000.0);
        List<DishesOrderWebOutDTO> list = Lists.newArrayList();
        ForkJoinPool pool = new ForkJoinPool();
        try {
            DishesOrderExcelTask task = new DishesOrderExcelTask(1,maxPage, queryWrapper, operatorId, dbName,baseMapper);
            Future<List<DishesOrderWebOutDTO>> future = pool.submit(task);
            do {
                pool.awaitTermination(1, TimeUnit.SECONDS);
            } while (!future.isDone());
            pool.shutdown();
            list = future.get();
        }catch (Exception e){
            e.printStackTrace();
            throw new BuilderException("餐单导出失败,请重新操作");
        }
        return list;
    }

    @Override
    public List<OrderCostWebOutDTO> OrderCostList(OrderCostWebInDTO orderCostWebInDTO) {
        Integer operatorId = TokenContext.cureOperatorId();
        QueryWrapper queryWrapper = webCostQuery(orderCostWebInDTO);
        int count = baseMapper.costOrderPageListAllSize(queryWrapper,dbName,operatorId);
        //每页1000条,计算总页数
        int maxPage = (int) Math.ceil(count/10000.0);
        List<OrderCostWebOutDTO> list = Lists.newArrayList();
        ForkJoinPool pool = new ForkJoinPool();
        try {
            CostOrderExcelTask task = new CostOrderExcelTask(1,maxPage, queryWrapper, operatorId, dbName,baseMapper);
            Future<List<OrderCostWebOutDTO>> future = pool.submit(task);
            do {
                pool.awaitTermination(1, TimeUnit.SECONDS);
            } while (!future.isDone());
            pool.shutdown();
            list = future.get();
        }catch (Exception e){
            e.printStackTrace();
            throw new BuilderException("成本核算导出失败,请重新操作");
        }
        return list;
    }

    private QueryWrapper webCostQuery(OrderCostWebInDTO orderWebInDTO) {
        QueryWrapper<Order> orderQueryWrapper = new QueryWrapper<>();
        String searchTime = "o.order_time";
        if(StringUtils.isNotBlank(orderWebInDTO.getSearchDateStr())){
            searchTime = orderWebInDTO.getSearchDateStr();
        }
        if (orderWebInDTO.getStartDate() != null) {
            orderQueryWrapper.ge("o."+searchTime, orderWebInDTO.getStartDate());
        }
        if (orderWebInDTO.getEndDate() != null) {
            orderQueryWrapper.le( "o."+searchTime, orderWebInDTO.getEndDate());
        }
        orderQueryWrapper.in( !orderWebInDTO.getSupplierIds().isEmpty(),"o.supplier_id", orderWebInDTO.getSupplierIds());
        if(orderWebInDTO.getStationIds() != null && !orderWebInDTO.getStationIds().isEmpty()){
            orderQueryWrapper.in( "o.station_id", orderWebInDTO.getStationIds());
        }

        if(orderWebInDTO.getServiceStationIds() != null && !orderWebInDTO.getServiceStationIds().isEmpty()){
            orderQueryWrapper.in( "o.service_station_id", orderWebInDTO.getServiceStationIds());
        }

        if(orderWebInDTO.getEmployeeId() != null){
            orderQueryWrapper.eq( "o.employee_id", orderWebInDTO.getEmployeeId());
        }

        if(StringUtils.isNotBlank(orderWebInDTO.getCode())){
            orderQueryWrapper.eq( "o.sn", orderWebInDTO.getCode());
        }
        orderQueryWrapper.eq( "o.status", 1);
        if(orderWebInDTO.getRevenueStatus() != null){
            orderQueryWrapper.eq( "o.revenue_status",orderWebInDTO.getRevenueStatus());
        }
        if(orderWebInDTO.getCostStatus() != null){
            orderQueryWrapper.eq( "o.cost_status",orderWebInDTO.getCostStatus());
        }
        orderQueryWrapper.orderByDesc("o.order_cost_id");

        return orderQueryWrapper;
    }


    private QueryWrapper webQuery(DishesOrderWebInDTO orderWebInDTO) {
        QueryWrapper<Order> orderQueryWrapper = new QueryWrapper<>();
        if (StringUtils.isNotBlank(orderWebInDTO.getSn())) {
            orderQueryWrapper.eq("o.sn", orderWebInDTO.getSn());
        }
        if (StringUtils.isNotBlank(orderWebInDTO.getCustomerName())) {
            orderQueryWrapper.eq( "o.customer_name", orderWebInDTO.getCustomerName());
        }
        if (StringUtils.isNotBlank(orderWebInDTO.getCustomerPhone())) {
            orderQueryWrapper.eq( "o.customer_phone", orderWebInDTO.getCustomerPhone());
        }
        if (orderWebInDTO.getPayStyle() != null) {
            orderQueryWrapper.like("o.pay_account", orderWebInDTO.getPayStyle());
        }
        if (orderWebInDTO.getStartDate() != null) {
            orderQueryWrapper.ge("o.order_time", orderWebInDTO.getStartDate());
        }
        if (orderWebInDTO.getEndDate() != null) {
            orderQueryWrapper.le("o.order_time", orderWebInDTO.getEndDate());
        }
        if (!org.springframework.util.CollectionUtils.isEmpty(orderWebInDTO.getSupplierIds())) {
            orderQueryWrapper.in("o.supplier_id", orderWebInDTO.getSupplierIds());
        }
        if (!org.springframework.util.CollectionUtils.isEmpty(orderWebInDTO.getStationIds())) {
            orderQueryWrapper.in("o.service_station_id", orderWebInDTO.getStationIds());
        }
        orderQueryWrapper.eq("o.pay_status",3);
        orderQueryWrapper.orderByDesc("o.order_id");
        return orderQueryWrapper;
    }

    private QueryWrapper orderServiceQuery(OrderServiceWebInDTO orderServiceWebInDTO, String prefix) {
        QueryWrapper<Order> orderQueryWrapper = new QueryWrapper<>();
        if (StringUtils.isNotBlank(orderServiceWebInDTO.getSearchValueCustomerName())) {
            orderQueryWrapper.eq(prefix + "customer_name", orderServiceWebInDTO.getSearchValueCustomerName());
        }
        if (StringUtils.isNotBlank(orderServiceWebInDTO.getSearchValuePhone())) {
            orderQueryWrapper.eq(prefix + "phone", orderServiceWebInDTO.getSearchValuePhone());
        }else if (StringUtils.isNotBlank(orderServiceWebInDTO.getPhone())) {
            orderQueryWrapper.eq(prefix + "phone", orderServiceWebInDTO.getPhone());
        }
        if (StringUtils.isNotBlank(orderServiceWebInDTO.getSearchValueName())) {
            orderQueryWrapper.eq(prefix + "name", orderServiceWebInDTO.getSearchValueName());
        }
        if (StringUtils.isNotBlank(orderServiceWebInDTO.getSearchValueIdNumber())) {
            orderQueryWrapper.eq(prefix + "id_number", orderServiceWebInDTO.getSearchValueIdNumber());
        }
        if (StringUtils.isNotBlank(orderServiceWebInDTO.getSearchValueEmployeeName())) {
            orderQueryWrapper.like(prefix + "employee_name", orderServiceWebInDTO.getSearchValueEmployeeName());
        }
        if (StringUtils.isNotBlank(orderServiceWebInDTO.getSearchValueOrderCode())) {
            orderQueryWrapper.eq(prefix + "sn", orderServiceWebInDTO.getSearchValueOrderCode());
        }
        if (null != orderServiceWebInDTO.getOrderStatus()) {
            if(orderServiceWebInDTO.getOrderStatus().equals(17)){
                //已回访
                orderQueryWrapper.eq(prefix + "visit_status",1);
            }else{
                orderQueryWrapper.eq(prefix + "order_status", orderServiceWebInDTO.getOrderStatus());
            }
        }
        if (null != orderServiceWebInDTO.getIsReturn()) {
            if(orderServiceWebInDTO.getIsReturn().equals(1)){
                orderQueryWrapper.ne(prefix + "return_num", 0);
            }else{
                orderQueryWrapper.eq(prefix + "return_num", 0);
            }
        }
        if (null != orderServiceWebInDTO.getPayStatus()) {
            orderQueryWrapper.eq(prefix + "pay_status", orderServiceWebInDTO.getPayStatus());
        }
        if (null != orderServiceWebInDTO.getPayStyle()) {
            orderQueryWrapper.eq(prefix + "pay_style", orderServiceWebInDTO.getPayStyle());
        }
        if (null != orderServiceWebInDTO.getEmployeeId()) {
            orderQueryWrapper.eq(prefix + "employee_id",orderServiceWebInDTO.getEmployeeId());
        }
        if (StringUtils.isNotBlank(orderServiceWebInDTO.getReviewReason())) {
            orderQueryWrapper.likeRight(prefix + "review_reason",orderServiceWebInDTO.getReviewReason());
        }
        if(orderServiceWebInDTO.getStationId() != null && orderServiceWebInDTO.getSource() != null){
            switch (orderServiceWebInDTO.getSource()){
                case 0:
                case 2:
                    orderQueryWrapper.eq(prefix + "service_station_id",orderServiceWebInDTO.getStationId());
                    break;
                case 1:
                    orderQueryWrapper.eq(prefix + "supplier_one_id",orderServiceWebInDTO.getStationId());
                    break;
            }
        }
        if(orderServiceWebInDTO.getServiceStationIds() != null && !orderServiceWebInDTO.getServiceStationIds().isEmpty()){
            List<Integer> oneList = orderServiceWebInDTO.getServiceStationIds().stream().filter(s->s<0).collect(Collectors.toList());
            List<Integer> supplierList = Lists.newArrayList();
            for (Integer integer : oneList) {
                supplierList.add(integer*-1);
            }
            List<Integer> twoList = orderServiceWebInDTO.getServiceStationIds().stream().filter(s->s>0).collect(Collectors.toList());

            if(!supplierList.isEmpty() && !twoList.isEmpty()){
                orderQueryWrapper.and(wr->wr.in(prefix + "supplier_one_id",supplierList).or().in(prefix + "service_station_id",twoList));
            }else if(!supplierList.isEmpty()){
                orderQueryWrapper.in(prefix + "supplier_one_id",supplierList);
            }else if(!twoList.isEmpty()){
                orderQueryWrapper.in(prefix + "service_station_id",twoList);
            }
        }
        if (orderServiceWebInDTO.getPayWay() != null) {
            orderQueryWrapper.eq(prefix + "pay_way", orderServiceWebInDTO.getPayWay());
        }
        if (null != orderServiceWebInDTO.getInvalidTime()) {
            orderQueryWrapper.eq(prefix + "invalid_time", orderServiceWebInDTO.getInvalidTime());
        }
        if (orderServiceWebInDTO.getStartDate() != null) {
            orderQueryWrapper.ge(prefix + "order_time", orderServiceWebInDTO.getStartDate());
        }
        if (orderServiceWebInDTO.getEndDate() != null) {
            orderQueryWrapper.le(prefix + "order_time", orderServiceWebInDTO.getEndDate());
        }
        if (orderServiceWebInDTO.getHomeStartDate() != null) {
            orderQueryWrapper.ge(prefix + "home_time", orderServiceWebInDTO.getHomeStartDate());
        }
        if (orderServiceWebInDTO.getHomeEndDate() != null) {
            orderQueryWrapper.le(prefix + "home_time", orderServiceWebInDTO.getHomeEndDate());
        }
        if (orderServiceWebInDTO.getFinishStartDate() != null) {
            orderQueryWrapper.ge(prefix + "finish_time", orderServiceWebInDTO.getFinishStartDate());
        }
        if (orderServiceWebInDTO.getFinishEndDate() != null) {
            orderQueryWrapper.le(prefix + "finish_time", orderServiceWebInDTO.getFinishEndDate());
        }
        if (orderServiceWebInDTO.getSearchStartDate() != null && StringUtils.isNotEmpty(orderServiceWebInDTO.getSearchDateStr())) {
            orderQueryWrapper.ge(prefix + orderServiceWebInDTO.getSearchDateStr(), orderServiceWebInDTO.getSearchStartDate());
        }
        if (orderServiceWebInDTO.getSearchEndDate() != null && StringUtils.isNotEmpty(orderServiceWebInDTO.getSearchDateStr())) {
            orderQueryWrapper.le(prefix + orderServiceWebInDTO.getSearchDateStr(), orderServiceWebInDTO.getSearchEndDate());
        }
        if (orderServiceWebInDTO.getVisitReserve() != null) {
            switch (orderServiceWebInDTO.getVisitReserve()){
                case 0:
                    orderQueryWrapper.isNotNull(prefix + "visit_reserve_date");
                    break;
                case 1:
                    orderQueryWrapper.isNull(prefix + "visit_reserve_date");
                    break;
            }
        }
        if (null != orderServiceWebInDTO.getPageType()) {
            if(orderServiceWebInDTO.getPageType().equals(15)){
                orderQueryWrapper.eq(prefix + "order_status", 15);
            }else if(orderServiceWebInDTO.getPageType().equals(16)){
                orderQueryWrapper.gt(prefix + "return_num", 0);
            }else if(orderServiceWebInDTO.getPageType().equals(17)){
                orderQueryWrapper.eq(prefix + "order_status",16);
            }else if(orderServiceWebInDTO.getPageType().equals(19)){
                orderQueryWrapper.eq(prefix + "visit_status", 1);
            }else if (orderServiceWebInDTO.getPageType().equals(11)) {
                orderQueryWrapper.in(prefix + "order_status", Lists.newArrayList(11,12));
            } else {
                orderQueryWrapper.eq(prefix + "order_status", orderServiceWebInDTO.getPageType());
            }
        }

        orderQueryWrapper.eq(orderServiceWebInDTO.getPlanId() != null,prefix + "plan_id", orderServiceWebInDTO.getPlanId());

        String station = prefix+"station_id";
        if(TokenContext.cureWebUser().getType()!= null &&
                (TokenContext.cureWebUser().getType().equals(2)||TokenContext.cureWebUser().getType().equals(12))){
            station = prefix+"service_station_id";
        }
        orderQueryWrapper.in(!orderServiceWebInDTO.getStationIds().isEmpty(),station,orderServiceWebInDTO.getStationIds());

        Integer supplierId = TokenContext.curSupplierId();
        Integer belong =  TokenContext.wbBelong();
        if(belong.equals(1)){
            //一级供应商
            if (supplierId != null && !supplierId.equals(-1)) {
                orderQueryWrapper.eq(prefix + "supplier_one_id", supplierId);
            }
        }else{
            orderQueryWrapper.in(!orderServiceWebInDTO.getSupplierIds().isEmpty(),prefix + "supplier_id",orderServiceWebInDTO.getSupplierIds());
        }

        orderQueryWrapper.eq(prefix + "order_type", 2);
        return orderQueryWrapper;
    }

    private List<ListParams> getSubsidyCustomerMealList(DateParams dateParams,List<Integer> operatorIds){
        List<ListParams> returnList = Lists.newArrayList();
        QueryWrapper queryWrapper = new QueryWrapper<>();
        if(dateParams.getStartDate() != null){
            queryWrapper.ge("meal_date",dateParams.getStartDate());
        }
        if(dateParams.getEndDate() != null){
            queryWrapper.lt("meal_date",dateParams.getEndDate());
        }
        for (Integer operatorId : operatorIds) {
            //获取签约客户信息
            List<Customer> dto = baseMapper.getSubsidyCustomerMealList(operatorId,dbName,queryWrapper);
            if(!dto.isEmpty()){
                Map<Integer,List<Customer>> streetMaps = dto.stream().filter(c->c.getNowStreetId() != null).collect(Collectors.groupingBy(Customer::getNowStreetId));
                getMealData(streetMaps,returnList);
                //按照区分组
                Map<Integer,List<Customer>> countryMaps = dto.stream().filter(c->c.getNowCountryId() != null).collect(Collectors.groupingBy(Customer::getNowCountryId));
                getMealData(countryMaps,returnList);
                //按照市分组
                Map<Integer,List<Customer>> cityMaps = dto.stream().filter(c->c.getNowCityId() != null).collect(Collectors.groupingBy(Customer::getNowCityId));
                getMealData(cityMaps,returnList);
            }
        }
        return returnList;
    }

    private void getMealData(Map<Integer,List<Customer>> maps,List<ListParams> returnList){

        for (Integer integer : maps.keySet()) {
            ListParams params = new ListParams();
            params.setId(integer);
            params.setKey(maps.get(integer).size());
            returnList.add(params);
        }
    }

    private List<CustomerSubsidyDTO> getSubsidyCustomerList(DateParams dateParams,List<Integer> operatorIds){

        List<CustomerSubsidyDTO> returnList = Lists.newArrayList();
        QueryWrapper queryWrapper = new QueryWrapper<>();
        if(dateParams.getStartDate() != null){
            queryWrapper.ge("d.created_date",dateParams.getStartDate());
        }
        if(dateParams.getEndDate() != null){
            queryWrapper.lt("d.created_date",dateParams.getEndDate());
        }
        for (Integer operatorId : operatorIds) {
            //获取签约客户信息
            List<CustomerSubsidyDTO> dto =baseMapper.getSubsidyCustomerList(operatorId,dbName,queryWrapper);
            if(!dto.isEmpty()){
                returnList.addAll(dto);
            }
        }
        return returnList;
    }

    private void changeZero(Map<Integer,List<Order>> maps,Date date){
        Calendar calendar = Calendar.getInstance();
        calendar.setTime(date);
        int day = calendar.get(Calendar.DAY_OF_MONTH);
        int week = calendar.get(Calendar.DAY_OF_WEEK);
        int hour = calendar.get(Calendar.HOUR_OF_DAY);
        for (Integer integer : maps.keySet()) {
            List<Order> orders = maps.get(integer);
            for (Order order : orders) {
                if(day == 1 && hour == 0){
                    //每月1日0点清零
                    order.setOrderNumMonth(0);
                    if(StringUtils.isNotEmpty(order.getMemberListData())){
                        MemberListData data =JSONObject.toJavaObject(JSON.parseObject(order.getMemberListData()), MemberListData.class);
                        data.setTotal(0);
                        order.setMemberListData(JSONObject.toJSONString(data));
                    }
                }
                if (week == Calendar.MONDAY && hour == 0) {
                    //每周一0点清零
                    order.setOrderNumWeek(0);
                }
                if(hour == 0){
                    //每天0点清零
                    order.setOrderNumDay(0);
                }
            }
        }
    }

    private void changeEmployee(Map<Integer, List<Order>> maps) {

        List<EmployeeStationFace> employeeStationFaces = this.getEmployeeStationFace();
        for (EmployeeStationFace employeeStationFace : employeeStationFaces) {
            List<Order> orders = maps.get(employeeStationFace.getAreaId());
            if(orders != null){
                for (Order order : orders) {
                    order.setAllStationNum(employeeStationFace.getAllStationNum());
                    order.setEmployeeNum(employeeStationFace.getNum());
                    order.setEmployeeList(employeeStationFace.getLists());
                }
            }

        }
    }

    private void getEmployeeData(Map<Integer,List<SupplierStation>> stationMaps, List<Employee> employeeList, List<SupplierStationEmployee> stationEmployeeList, List<EmployeeStationFace> returnList){
        for (Integer integer : stationMaps.keySet()) {
            List<SupplierStation> stations = stationMaps.get(integer);
            if(org.springframework.util.CollectionUtils.isEmpty(stations)){
                continue;
            }
            EmployeeStationFace face = new EmployeeStationFace();
            face.setAreaId(integer);

            List<Integer> stationIds = stations.stream().map(s->s.getId()).collect(Collectors.toList());
            List<Integer> employeeIds = stationEmployeeList.stream().filter(se->stationIds.contains(se.getStationId())).map(se->se.getEmployeeId()
            ).distinct().collect(Collectors.toList());
            List<Employee> employees = employeeList.stream().filter(e->employeeIds.contains(e.getId())).collect(Collectors.toList());

            face.setAllStationNum(stationIds.size());
            face.setNum(employees.size());
            EmployeeStationJsonFace json = new EmployeeStationJsonFace();
            json.setTotal(face.getNum());
            json.setTitle(Lists.newArrayList("30以下","30-39","40-49","50-59","60及以上"));
            //按照年龄30以下,30-39,40-49,50-59,60以上
            List<String> maleList = Lists.newArrayList();
            List<String> womanList = Lists.newArrayList();
            List<Employee> thirtyDown = employees.stream().filter(e->e.getAge()<30).collect(Collectors.toList());
            Long thirtyDownMale = thirtyDown.stream().filter(e->e.getGender().equals(1)).count();
            Long thirtyDownWoman = thirtyDown.stream().filter(e->e.getGender().equals(0)).count();
            maleList.add(thirtyDownMale.toString());
            womanList.add(thirtyDownWoman.toString());
            List<Employee> thirty = employees.stream().filter(e->e.getAge()>=30 && e.getAge()<40).collect(Collectors.toList());
            Long thirtyMale = thirty.stream().filter(e->e.getGender().equals(1)).count();
            Long thirtyWoman = thirty.stream().filter(e->e.getGender().equals(0)).count();
            maleList.add(thirtyMale.toString());
            womanList.add(thirtyWoman.toString());
            List<Employee> forty = employees.stream().filter(e->e.getAge()>=40 && e.getAge()<50).collect(Collectors.toList());
            Long fortyMale = forty.stream().filter(e->e.getGender().equals(1)).count();
            Long fortyWoman = forty.stream().filter(e->e.getGender().equals(0)).count();
            maleList.add(fortyMale.toString());
            womanList.add(fortyWoman.toString());
            List<Employee> fifty = employees.stream().filter(e->e.getAge()>=50 && e.getAge()<60).collect(Collectors.toList());
            Long fiftyMale = fifty.stream().filter(e->e.getGender().equals(1)).count();
            Long fiftyWoman = fifty.stream().filter(e->e.getGender().equals(0)).count();
            maleList.add(fiftyMale.toString());
            womanList.add(fiftyWoman.toString());
            List<Employee> sixtyUp = employees.stream().filter(e->e.getAge()>=60).collect(Collectors.toList());
            Long sixtyUpMale = sixtyUp.stream().filter(e->e.getGender().equals(1)).count();
            Long sixtyUpWoman = sixtyUp.stream().filter(e->e.getGender().equals(0)).count();
            maleList.add(sixtyUpMale.toString());
            womanList.add(sixtyUpWoman.toString());
            //按照性别分组
            json.setMale(maleList);
            json.setWoman(womanList);
            face.setLists(JSONObject.toJSONString(json));
            returnList.add(face);
        }
    }


    private List<EmployeeStationFace> getEmployeeStationFace(){
        List<EmployeeStationFace> returnList = Lists.newArrayList();
        //获取驿站员工信息
        List<SupplierStationEmployee> stationEmployeeList = baseMapper.supplierStationEmployeeList(dbName);
        //获取驿站
        List<SupplierStation> stationList = baseMapper.supplierStationList(dbName);
        //获取员工
        List<Employee> employeeList = baseMapper.employeeList(dbName);

        //按照街道分组
        Map<Integer,List<SupplierStation>> stationStreetMaps = stationList.stream().filter(s->s.getStreet() != null).collect(Collectors.groupingBy(SupplierStation::getStreet));
        getEmployeeData(stationStreetMaps,employeeList,stationEmployeeList,returnList);
        //按照区分组
        Map<Integer,List<SupplierStation>> stationCountryMaps = stationList.stream().filter(s->s.getCountry() != null).collect(Collectors.groupingBy(SupplierStation::getCountry));
        getEmployeeData(stationCountryMaps,employeeList,stationEmployeeList,returnList);
        //按照市分组
        Map<Integer,List<SupplierStation>> stationCityMaps = stationList.stream().filter(s->s.getCity() != null).collect(Collectors.groupingBy(SupplierStation::getCity));
        getEmployeeData(stationCityMaps,employeeList,stationEmployeeList,returnList);

        return returnList;
    }

    private List<SubsidyCustomerFace> getSubsidyCustomerFace(List<CustomerSubsidyDTO> customerList){

        List<SubsidyCustomerFace> returnList = Lists.newArrayList();

        //按照街道分组
        Map<Integer,List<CustomerSubsidyDTO>> streetMaps = customerList.stream().filter(c->c.getNowStreetId() != null).collect(Collectors.groupingBy(CustomerSubsidyDTO::getNowStreetId));
        fillData(streetMaps,returnList,3);
        //按照区分组
        Map<Integer,List<CustomerSubsidyDTO>> countryMaps = customerList.stream().filter(c->c.getNowCountryId() != null).collect(Collectors.groupingBy(CustomerSubsidyDTO::getNowCountryId));
        fillData(countryMaps,returnList,2);
        //按照市分组
        Map<Integer,List<CustomerSubsidyDTO>> cityMaps = customerList.stream().filter(c->c.getNowCityId() != null).collect(Collectors.groupingBy(CustomerSubsidyDTO::getNowCityId));
        fillData(cityMaps,returnList,1);
//      //探访关爱--已单独汇总，此处不再处理
//      customerSubsidyVisitService.processCare(returnList,operatorIds);
        return returnList;
    }


    private void fillData(Map<Integer,List<CustomerSubsidyDTO>> maps, List<SubsidyCustomerFace> returnList,Integer source){
        for (Integer integer : maps.keySet()) {
            List<CustomerSubsidyDTO> csList = maps.get(integer);
            SubsidyCustomerFace face = new SubsidyCustomerFace();
            face.setAreaId(integer);
            face.setNum(csList.size());
            face.setCareAllMember(csList.stream().mapToInt(e-> org.apache.commons.lang.StringUtils.isNotEmpty(e.getCustomerSignId())?1:0).sum());
            List<Long> ids = csList.stream().map(c->c.getCustomerId()).collect(Collectors.toList());
            face.setCustomerIds(ids);
            // List<Long> intersectionList = (List<Long>) CollectionUtils.intersection(face.getCustomerIds(),cardCustomer);
            face.setCustomerGovernmentNum(csList.stream().filter(c->c.getCategory().equals(1)).collect(Collectors.toList()).size());
            face.setCustomerSocietyNum(face.getNum()-face.getCustomerGovernmentNum());
            face.setAllCustomerNum(csList.stream().filter(c ->c.getAge() != null && c.getAge() >= 75).collect(Collectors.toList()).size());

            MemberListData data = new MemberListData();
            Long totalDetailList = csList.stream().filter(d -> d.getCategory().equals(1)).count();
            data.setTotal(Integer.parseInt(totalDetailList.toString()));
            data.setTitle(Lists.newArrayList("50以下","50-59", "60-69", "70-79", "80-89", "90及以上"));
            List<Integer> maleAgeList = Lists.newArrayList();
            maleAgeList.add(csList.stream().filter(c ->c.getCategory().equals(1) && c.getSex() != null && c.getAge() != null && c.getSex().equals(1) && c.getAge() < 50).collect(Collectors.toList()).size());
            maleAgeList.add(csList.stream().filter(c ->c.getCategory().equals(1) &&  c.getSex() != null && c.getAge() != null && c.getSex().equals(1) && c.getAge() >= 50 && c.getAge() < 60).collect(Collectors.toList()).size());
            maleAgeList.add(csList.stream().filter(c ->c.getCategory().equals(1) &&  c.getSex() != null && c.getAge() != null && c.getSex().equals(1) && c.getAge() >= 60 && c.getAge() < 70).collect(Collectors.toList()).size());
            maleAgeList.add(csList.stream().filter(c ->c.getCategory().equals(1) &&  c.getSex() != null && c.getAge() != null && c.getSex().equals(1) && c.getAge() >= 70 && c.getAge() < 80).collect(Collectors.toList()).size());
            maleAgeList.add(csList.stream().filter(c ->c.getCategory().equals(1) &&  c.getSex() != null && c.getAge() != null && c.getSex().equals(1) && c.getAge() >= 80 && c.getAge() < 90).collect(Collectors.toList()).size());
            maleAgeList.add(csList.stream().filter(c ->c.getCategory().equals(1) &&  c.getSex() != null && c.getAge() != null && c.getSex().equals(1) && c.getAge() >= 90).collect(Collectors.toList()).size());
            data.setMale(maleAgeList);
            List<Integer> womanAgeList = Lists.newArrayList();
            womanAgeList.add(csList.stream().filter(c ->c.getCategory().equals(1) &&  c.getSex() != null && c.getAge() != null && c.getSex().equals(0) && c.getAge() < 50).collect(Collectors.toList()).size());
            womanAgeList.add(csList.stream().filter(c ->c.getCategory().equals(1) &&  c.getSex() != null && c.getAge() != null && c.getSex().equals(0) && c.getAge() >= 50 && c.getAge() < 60).collect(Collectors.toList()).size());
            womanAgeList.add(csList.stream().filter(c ->c.getCategory().equals(1) &&  c.getSex() != null && c.getAge() != null && c.getSex().equals(0) && c.getAge() >= 60 && c.getAge() < 70).collect(Collectors.toList()).size());
            womanAgeList.add(csList.stream().filter(c ->c.getCategory().equals(1) &&  c.getSex() != null && c.getAge() != null && c.getSex().equals(0) && c.getAge() >= 70 && c.getAge() < 80).collect(Collectors.toList()).size());
            womanAgeList.add(csList.stream().filter(c ->c.getCategory().equals(1) &&  c.getSex() != null && c.getAge() != null && c.getSex().equals(0) && c.getAge() >= 80 && c.getAge() < 90).collect(Collectors.toList()).size());
            womanAgeList.add(csList.stream().filter(c ->c.getCategory().equals(1) &&  c.getSex() != null && c.getAge() != null && c.getSex().equals(0) && c.getAge() >= 90).collect(Collectors.toList()).size());
            data.setWoman(womanAgeList);
            face.setCustomerAgeListData(data);

            List<SubsidyCustomerJsonFace> jsonFaceList = Lists.newArrayList();
            if(source.equals(1)){
                //按区域分组
                Map<Integer,List<CustomerSubsidyDTO>> countryMaps = csList.stream().collect(Collectors.groupingBy(CustomerSubsidyDTO::getNowCountryId));
                for (Integer key : countryMaps.keySet()) {
                    List<CustomerSubsidyDTO> keyList = countryMaps.get(key);
                    SubsidyCustomerJsonFace jsonFace = new SubsidyCustomerJsonFace();
                    jsonFace.setAreaId(key);
                    jsonFace.setTitle(keyList.get(0).getNowCountryName());
                    jsonFace.setTotal(keyList.size());
                    jsonFace.setCustomerIds(keyList.stream().map(c->c.getCustomerId()).collect(Collectors.toList()));
                    jsonFaceList.add(jsonFace);
                }
            }else{
                //按老人类型分组
                Map<String,List<CustomerSubsidyDTO>> typeMaps = csList.stream().collect(Collectors.groupingBy(CustomerSubsidyDTO::getCustomerTypeId));
                Map<String,SubsidyCustomerJsonFace> faceMap = new HashMap<>();
                for (String key : typeMaps.keySet()) {
                    List<CustomerSubsidyDTO> keyList = typeMaps.get(key);
                    List<Long> idList = keyList.stream().map(CustomerSubsidyDTO::getCustomerId).collect(Collectors.toList());
                    String customerType = keyList.get(0).getCustomerType();
                    if (key.contains(",")){
                        String[] typeIds = key.split(",");
                        String[] names = customerType.split(",");
                        for (int i=0; i<typeIds.length; i++){
                            mergeJsonFace(faceMap, typeIds[i], idList, names[i]);
                        }
                    }else{
                        mergeJsonFace(faceMap, key, idList, customerType);
                    }
                }
                jsonFaceList.addAll(faceMap.values());
            }

            face.setJsonFace(jsonFaceList);
            returnList.add(face);
        }
    }

    private void mergeJsonFace(Map<String, SubsidyCustomerJsonFace> faceMap, String key, List<Long> idList, String customerType) {
        SubsidyCustomerJsonFace jsonFace = faceMap.get(key);
        if (jsonFace== null){
            jsonFace = new SubsidyCustomerJsonFace();
            jsonFace.setAreaId(Integer.parseInt(key));
            jsonFace.setTitle(customerType);
            jsonFace.setTotal(idList.size());
            jsonFace.setCustomerIds(idList);
            faceMap.put(key, jsonFace);
        }else{
            jsonFace.getCustomerIds().addAll(idList);
            jsonFace.setTotal(jsonFace.getCustomerIds().size());
        }
    }

    private List<CustomerServiceParams> orderServiceCustomerList(List<Integer> operatorIds){
        List<CustomerServiceParams> returnList = Lists.newArrayList();
        for (Integer operatorId : operatorIds) {
            returnList.addAll(baseMapper.orderServiceCustomerList(operatorId,dbName));
        }
        return returnList;
    }

    private void changeCustomer(Map<Integer, List<Order>> maps,List<CustomerSubsidyDTO> customerList,List<Integer> operatorIds) {
        //更新客户数据
        List<SubsidyCustomerFace> customerFaceList = this.getSubsidyCustomerFace(customerList);
        //获取已服务老人Id集合
        List<CustomerServiceParams> serviceCustomerList = this.orderServiceCustomerList(operatorIds);
        for (SubsidyCustomerFace subsidyCustomerFace : customerFaceList) {
            List<Order> orders = maps.get(subsidyCustomerFace.getAreaId());
            if(orders == null || orders.isEmpty()){
                continue;
            }
            for (Order order : orders) {
                order.setCustomerNum((order.getCustomerNum()==null?0:order.getCustomerNum())+subsidyCustomerFace.getNum());
                order.setCustomerGovernmentNum((order.getCustomerGovernmentNum()==null?0:order.getCustomerGovernmentNum())+subsidyCustomerFace.getCustomerGovernmentNum());
                order.setCustomerSocietyNum((order.getCustomerSocietyNum()==null?0:order.getCustomerSocietyNum())+subsidyCustomerFace.getCustomerSocietyNum());
                order.setCareRate(BigDecimal.ZERO);
                order.setAllCustomerNum(order.getAllCustomerNum()+ subsidyCustomerFace.getAllCustomerNum());
                order.setCareNum(0);
                order.setCarePic("");
                order.setCareMember(0);
                order.setCareAllMember(0);
                //已服务老人数
                Long serviceSum = 0L;
                if(order.getSourceLevel() == 1){
                    serviceSum = serviceCustomerList.stream().filter(s->order.getAreaId().equals(s.getCityId())).mapToLong(s->s.getCustomerNum()).sum();
                }else if(order.getSourceLevel() == 2){
                    serviceSum = serviceCustomerList.stream().filter(s->order.getAreaId().equals(s.getCountryId())).mapToLong(s->s.getCustomerNum()).sum();
                }else{
                    serviceSum = serviceCustomerList.stream().filter(s->order.getAreaId().equals(s.getStreetId())).mapToLong(s->s.getCustomerNum()).sum();
                }
                order.setCustomerServiceNum(serviceSum.intValue());
                if(order.getCustomerNum().equals(0)){
                    order.setCustomerRate(BigDecimal.ZERO);
                }else{
                    BigDecimal decimal = new BigDecimal(order.getCustomerServiceNum()).divide(new BigDecimal(order.getCustomerNum()),4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal(100.0)).setScale(2,BigDecimal.ROUND_HALF_UP);
                    log.info("CustomerRate==="+decimal);
                    order.setCustomerRate(decimal);
                }
                List<SubsidyCustomerJsonFace> jsonFace = subsidyCustomerFace.getJsonFace();
                List<String> id = Lists.newArrayList();
                List<String> title = Lists.newArrayList();
                List<Integer> total = Lists.newArrayList();
                List<BigDecimal> rate = Lists.newArrayList();
                if(StringUtils.isNotEmpty(order.getCustomerList())){
                    JSONObject jsonObject = new JSONObject(JSON.parseObject(order.getCustomerList()));
                    SubsidyCustomerJsonVo vo = JSONObject.toJavaObject(jsonObject, SubsidyCustomerJsonVo.class);
                    if(!vo.getId().isEmpty()){
                        id.addAll(vo.getId());
                    }
                    title.addAll(vo.getTitle());
                    total.addAll(vo.getTotal());
                    rate.addAll(vo.getRate());
                }

                for (SubsidyCustomerJsonFace face : jsonFace) {
                    Integer num = face.getTotal();
                    Long sum = 0L;
                    if(serviceCustomerList != null && !serviceCustomerList.isEmpty() && order.getSourceLevel().equals(1)){
                        sum = serviceCustomerList.stream().filter(s->(face.getAreaId().equals(s.getCountryId()) || face.getAreaId().equals(s.getStreetId()))).mapToLong(s->s.getCustomerNum()).sum();
                    }else{
                        if(order.getSourceLevel().equals(2)){
                            sum = serviceCustomerList.stream().filter(s->s.getCountryId().equals(order.getAreaId()) && StringUtils.isNotEmpty(s.getCustomerTypeId()) && s.getCustomerTypeId().contains(","+face.getAreaId().toString()+",")).mapToLong(s->s.getCustomerNum()).sum();
                        }else if (order.getSourceLevel().equals(3) ){
                            sum = serviceCustomerList.stream().filter(s->s.getStreetId().equals(order.getAreaId()) && StringUtils.isNotEmpty(s.getCustomerTypeId()) && s.getCustomerTypeId().contains(","+face.getAreaId().toString()+",")).mapToLong(s->s.getCustomerNum()).sum();
                        }
                     }
                    if(id.contains(face.getAreaId().toString())){
                        for (int i = 0; i < id.size(); i++) {
                            if(id.get(i).equals(face.getAreaId().toString())){
                                total.set(i,total.get(i)+face.getTotal());
                                num = total.get(i);
                                if(num == 0L){
                                    rate.set(i,BigDecimal.ZERO);
                                }else{
                                    BigDecimal val = new BigDecimal(sum).divide(new BigDecimal(num),4, BigDecimal.ROUND_HALF_UP);
                                    BigDecimal decimal2 = val.multiply(new BigDecimal("100.0")).setScale(2,BigDecimal.ROUND_HALF_UP);
                                    rate.set(i,decimal2);
                                }
                                break;
                            }
                        }
                    }else{
                        id.add(face.getAreaId().toString());
                        title.add(face.getTitle());
                        total.add(face.getTotal());
                        if(num == 0L){
                            rate.add(BigDecimal.ZERO);
                        }else {
                            BigDecimal decimal2 = new BigDecimal(sum).divide(new BigDecimal(num), 4, BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal(100.0)).setScale(2, BigDecimal.ROUND_HALF_UP);
                            rate.add(decimal2);
                        }
                    }
                }
                SubsidyCustomerJsonVo vo = new SubsidyCustomerJsonVo();
                vo.setId(id);
                vo.setTitle(title);
                vo.setTotal(total);
                vo.setRate(rate);
                order.setCustomerList(JSONObject.toJSONString(vo));

                if(StringUtils.isNotEmpty(order.getCustomerAgeList()) && subsidyCustomerFace.getCustomerAgeListData() != null){
                    MemberListData data =JSONObject.toJavaObject(JSON.parseObject(order.getCustomerAgeList()), MemberListData.class);
                    MemberListData newData = subsidyCustomerFace.getCustomerAgeListData();

                    data.setTotal(data.getTotal()+newData.getTotal());

                    for (int i = 0; i < data.getMale().size(); i++) {
                        data.getMale().set(i,data.getMale().get(i)+newData.getMale().get(i));
                    }

                    for (int i = 0; i < data.getWoman().size(); i++) {
                        data.getWoman().set(i,data.getWoman().get(i)+newData.getWoman().get(i));
                    }
                    order.setCustomerAgeList(JSONObject.toJSONString(data));
                }else if(subsidyCustomerFace.getCustomerAgeListData() != null){
                    order.setCustomerAgeList(JSONObject.toJSONString(subsidyCustomerFace.getCustomerAgeListData()));
                }
            }
        }
    }

    private List<SubsidyCustomerFace> integralCustomer(DateParams dateParams){
        List<SubsidyCustomerFace> returnList = Lists.newArrayList();
        QueryWrapper detailQueryWrapper = new QueryWrapper<>();
        if(dateParams.getStartDate() != null){
            detailQueryWrapper.ge("created_date",dateParams.getStartDate());
        }
        if(dateParams.getEndDate() != null){
            detailQueryWrapper.le("created_date",dateParams.getEndDate());
        }
        List<Integer> operationIds =  baseMapper.getIntegralCardAccOperatorIdList(dbName,detailQueryWrapper);

        List<IntegralTrans> detailsCustomer = Lists.newArrayList();
        QueryWrapper queryWrapper = new QueryWrapper();
        if(dateParams.getStartDate() != null){
            queryWrapper.ge("d.created_date",dateParams.getStartDate());
        }
        if(dateParams.getEndDate() != null){
            queryWrapper.le("d.created_date",dateParams.getEndDate());
        }

        for (Integer operationId : operationIds) {
            //获取积分数据
            detailsCustomer.addAll(baseMapper.integralCustomerList(queryWrapper,operationId,dbName));
        }

        log.info("---处理积分客户数据开始----");
        if(!detailsCustomer.isEmpty()){
            Map<Integer,List<IntegralTrans>> streetCustomerMaps = detailsCustomer.stream().filter(i->i.getStreetId() != null).collect(Collectors.groupingBy(IntegralTrans::getStreetId));
            fillData(streetCustomerMaps,returnList);

            Map<Integer,List<IntegralTrans>> cityCustomerMaps = detailsCustomer.stream().filter(i->i.getCityId() != null).collect(Collectors.groupingBy(IntegralTrans::getCityId));
            fillData(cityCustomerMaps,returnList);

            Map<Integer,List<IntegralTrans>> countryCustomerMaps = detailsCustomer.stream().filter(i->i.getCountryId() != null).collect(Collectors.groupingBy(IntegralTrans::getCountryId));
            fillData(countryCustomerMaps,returnList);
        }

        log.info("---处理积分客户数据结束----");
        return returnList;
    }

    private void fillData(Map<Integer,List<IntegralTrans>> mapCustomerData, List<SubsidyCustomerFace> returnList){
        for (Integer integer : mapCustomerData.keySet()) {
            List<IntegralTrans> csList = mapCustomerData.get(integer);
            SubsidyCustomerFace face = new SubsidyCustomerFace();
            face.setAreaId(integer);
            face.setCustomerNum(csList.size());

            MemberListData data = new MemberListData();
            List<IntegralTrans> totalDetailList = csList.stream().filter(d -> d.getCreatedDate().after(com.poteviohealth.cgp.common.utils.DateUtils.getFirstDayOfMonth(new Date()))).collect(Collectors.toList());
            data.setTotal(totalDetailList.size());
            data.setTitle(Lists.newArrayList("60以下", "60-69", "70-79", "80-89", "90及以上"));
            List<Integer> maleAgeList = Lists.newArrayList();
            maleAgeList.add(csList.stream().filter(c -> c.getSex() != null && c.getAge() != null && c.getSex().equals(1) && c.getAge() < 60).collect(Collectors.toList()).size());
            maleAgeList.add(csList.stream().filter(c -> c.getSex() != null && c.getAge() != null && c.getSex().equals(1) && c.getAge() >= 60 && c.getAge() < 70).collect(Collectors.toList()).size());
            maleAgeList.add(csList.stream().filter(c -> c.getSex() != null && c.getAge() != null && c.getSex().equals(1) && c.getAge() >= 70 && c.getAge() < 80).collect(Collectors.toList()).size());
            maleAgeList.add(csList.stream().filter(c -> c.getSex() != null && c.getAge() != null && c.getSex().equals(1) && c.getAge() >= 80 && c.getAge() < 90).collect(Collectors.toList()).size());
            maleAgeList.add(csList.stream().filter(c -> c.getSex() != null && c.getAge() != null && c.getSex().equals(1) && c.getAge() >= 90).collect(Collectors.toList()).size());
            data.setMale(maleAgeList);
            List<Integer> womanAgeList = Lists.newArrayList();
            womanAgeList.add(csList.stream().filter(c -> c.getSex() != null && c.getAge() != null && c.getSex().equals(0) && c.getAge() < 60).collect(Collectors.toList()).size());
            womanAgeList.add(csList.stream().filter(c -> c.getSex() != null && c.getAge() != null && c.getSex().equals(0) && c.getAge() >= 60 && c.getAge() < 70).collect(Collectors.toList()).size());
            womanAgeList.add(csList.stream().filter(c -> c.getSex() != null && c.getAge() != null && c.getSex().equals(0) && c.getAge() >= 70 && c.getAge() < 80).collect(Collectors.toList()).size());
            womanAgeList.add(csList.stream().filter(c -> c.getSex() != null && c.getAge() != null && c.getSex().equals(0) && c.getAge() >= 80 && c.getAge() < 90).collect(Collectors.toList()).size());
            womanAgeList.add(csList.stream().filter(c -> c.getSex() != null && c.getAge() != null && c.getSex().equals(0) && c.getAge() >= 90).collect(Collectors.toList()).size());
            data.setWoman(womanAgeList);
            face.setMemberListData(data);

            returnList.add(face);
        }
    }

    private void changeCustomerIntegral(Map<Integer, List<Order>> maps,DateParams dateParams) {
        List<SubsidyCustomerFace> integralList = this.integralCustomer(dateParams);
        Calendar calendar2 = Calendar.getInstance();
        calendar2.setTime(dateParams.getEndDate());
        int day = calendar2.get(Calendar.DAY_OF_MONTH);
        int hour = calendar2.get(Calendar.HOUR_OF_DAY);

        for (SubsidyCustomerFace subsidyCustomerFace : integralList) {
            List<Order> orders = maps.get(subsidyCustomerFace.getAreaId());
            if (CollectionUtils.isEmpty(orders)) {
                continue;
            }
            for (Order order : orders) {
                //积分相关
                if(order.getPointMember() == null){
                    order.setPointMember(0);
                }
                if(subsidyCustomerFace.getCustomerNum() != null){
                    Integer num =order.getPointMember()+subsidyCustomerFace.getCustomerNum();
                    order.setPointMember(num);
                }

                if(StringUtils.isNotEmpty(order.getMemberListData()) && subsidyCustomerFace.getMemberListData() != null){
                    MemberListData data =JSONObject.toJavaObject(JSON.parseObject(order.getMemberListData()), MemberListData.class);
                    MemberListData newData = subsidyCustomerFace.getMemberListData();

                    if(day == 1 && hour == 0){
                        data.setTotal(newData.getTotal());

                    }else{
                        data.setTotal(data.getTotal()+newData.getTotal());
                    }

                    for (int i = 0; i < data.getMale().size(); i++) {
                        data.getMale().set(i,data.getMale().get(i)+newData.getMale().get(i));
                    }

                    for (int i = 0; i < data.getWoman().size(); i++) {
                        data.getWoman().set(i,data.getWoman().get(i)+newData.getWoman().get(i));
                    }
                    order.setMemberListData(JSONObject.toJSONString(data));
                }else if(subsidyCustomerFace.getMemberListData() != null){
                    order.setMemberListData(JSONObject.toJSONString(subsidyCustomerFace.getMemberListData()));
                }

            }
        }
    }


    private List<SubsidyCustomerFace> integralTrans(DateParams dateParams){
        List<SubsidyCustomerFace> returnList = Lists.newArrayList();
        List<Integer> operationIds = baseMapper.getIntegralCardDetailOperatorIdList(dbName);
        List<IntegralTrans> detailsTrans = Lists.newArrayList();
        QueryWrapper queryWrapper2 = new QueryWrapper();
        if(dateParams.getStartDate() != null){
            queryWrapper2.ge("t.build_time",dateParams.getStartDate());
        }
        if(dateParams.getEndDate() != null){
            queryWrapper2.le("t.build_time",dateParams.getEndDate());
        }
        for (Integer operationId : operationIds) {
            //获取积分数据
            detailsTrans.addAll(baseMapper.integralTransList(queryWrapper2,operationId,dbName));
        }

        log.info("---处理流水数据开始----");
        Map<Integer,List<IntegralTrans>> streetTransMaps = detailsTrans.stream().filter(i->i.getStreetId() != null).collect(Collectors.groupingBy(IntegralTrans::getStreetId));

        fillData2(streetTransMaps,returnList);
        Map<Integer,List<IntegralTrans>> cityTransMaps = detailsTrans.stream().filter(i->i.getCityId() != null).collect(Collectors.groupingBy(IntegralTrans::getCityId));

        fillData2(cityTransMaps,returnList);
        Map<Integer,List<IntegralTrans>> countryTransMaps = detailsTrans.stream().filter(i->i.getCountryId() != null).collect(Collectors.groupingBy(IntegralTrans::getCountryId));

        fillData2(countryTransMaps,returnList);
        log.info("---处理流水数据结束----");
        return returnList;
    }

    private void fillData2(Map<Integer,List<IntegralTrans>> data2,List<SubsidyCustomerFace> returnList){
        for (Integer integer : data2.keySet()) {
            List<IntegralTrans> dataList = data2.get(integer);
            SubsidyCustomerFace face = new SubsidyCustomerFace();
            face.setAreaId(integer);

            Long grantSum = dataList.stream().filter(t -> t.getTransType().equals("0")).mapToLong(t -> t.getAmount()).sum();
            face.setGrantNum(grantSum);
            Long exchangeSum = dataList.stream().filter(t -> t.getTransType().equals("1")).mapToLong(t -> t.getAmount()).sum();
            face.setExchangeNum(exchangeSum);
            List<MonthData> goodsList = Lists.newArrayList();
            Map<Integer, List<IntegralTrans>> maps = dataList.stream().filter(i -> i.getParentId() != null).collect(Collectors.groupingBy(IntegralTrans::getParentId));
            for (Integer categoryId : maps.keySet()) {
                List<IntegralTrans> categoryList = maps.get(categoryId);
                MonthData monthData = new MonthData();
                monthData.setAddValue(0L);
                for (IntegralTrans IntegralTrans : categoryList) {
                    String fullName = IntegralTrans.getFullName();
                    if (fullName.contains("/")) {
                        fullName = fullName.split("/")[0];
                    }
                    monthData.setText(fullName);
                    monthData.setAddValue(monthData.getAddValue() + IntegralTrans.getAmount());
                }
                if (monthData.getAddValue() > 0L) {
                    goodsList.add(monthData);
                }
            }
            //消分商品个数统计
            if (!goodsList.isEmpty()) {
                face.setPointGoodsData2(goodsList);
            }
            face.setPointMonthData(addMonth(dataList, 0));
            face.setPointCountData(addMonth(dataList, 1));
            returnList.add(face);
        }
    }

    private List<MonthData> addMonth(List<IntegralTrans> transList,Integer type){
        Date endDate = new Date();
        Calendar calendar = Calendar.getInstance();
        calendar.setTime(com.poteviohealth.cgp.common.utils.DateUtils.getLastDayOfMonth(endDate));
        calendar.add(Calendar.SECOND,1);
        calendar.add(Calendar.YEAR, -1);
        Date startDate = calendar.getTime();
        List<MonthData> monthList = Lists.newArrayList();
        Calendar calendar2 = Calendar.getInstance();
        for (int i = 0; i < 12; i++) {
            if(i>0){
                calendar2.add(Calendar.MONTH, 1);
            }else{
                calendar2.setTime(startDate);
            }
            String monthStr = String.format("%02d",  calendar2.get(Calendar.MONTH)+1);
            MonthData data = new MonthData();
            data.setText(monthStr+"月");
            if(type.equals(0)){
                if(transList.isEmpty()){
                    data.setAddValue(0L);
                    data.setUseValue(0L);
                }else{
                    data.setAddValue(transList.stream().filter(c->c.getBuildTime().after(calendar2.getTime()) && c.getBuildTime().before(com.poteviohealth.cgp.common.utils.DateUtils.getLastDayOfMonth(calendar2.getTime())) && c.getTransType().equals("0")).mapToLong(c->c.getAmount()).sum());
                    data.setUseValue(transList.stream().filter(c->c.getBuildTime().after(calendar2.getTime()) && c.getBuildTime().before(com.poteviohealth.cgp.common.utils.DateUtils.getLastDayOfMonth(calendar2.getTime())) && c.getTransType().equals("1")).mapToLong(c->c.getAmount()).sum());
                }

            }else {
                if (transList.isEmpty()) {
                    data.setAddValue(0L);
                    data.setUseValue(0L);
                } else {
                    data.setAddValue(transList.stream().filter(c -> c.getBuildTime().after(calendar2.getTime()) && c.getBuildTime().before(com.poteviohealth.cgp.common.utils.DateUtils.getLastDayOfMonth(calendar2.getTime())) && c.getTransType().equals("0")).count());
                    data.setUseValue(transList.stream().filter(c -> c.getBuildTime().after(calendar2.getTime()) && c.getBuildTime().before(com.poteviohealth.cgp.common.utils.DateUtils.getLastDayOfMonth(calendar2.getTime())) && c.getTransType().equals("1")).count());
                }
            }
            monthList.add(data);
        }
        return monthList;
    }

    private void changeTransIntegral(Map<Integer, List<Order>> maps,DateParams dateParams) {
        List<SubsidyCustomerFace> integralList = this.integralTrans(dateParams);

        for (SubsidyCustomerFace subsidyCustomerFace : integralList) {
            List<Order> orders = maps.get(subsidyCustomerFace.getAreaId());
            if (CollectionUtils.isEmpty(orders)) {
                continue;
            }
            for (Order order : orders) {
                //积分相关
                if(order.getPointGrant() == null){
                    order.setPointGrant(0L);
                }
                if(subsidyCustomerFace.getGrantNum() != null){
                    Long num = order.getPointGrant()+subsidyCustomerFace.getGrantNum();
                    order.setPointGrant(num);
                }
                if(order.getPointExchange() == null){
                    order.setPointExchange(0L);
                }
                if(subsidyCustomerFace.getExchangeNum() != null){
                    Long num =order.getPointExchange() + subsidyCustomerFace.getExchangeNum();
                    order.setPointExchange(num);
                }

                if(StringUtils.isNotEmpty(order.getPointGoodsData2()) && CollectionUtils.isNotEmpty(subsidyCustomerFace.getPointGoodsData2())){
                    List<MonthData> list =JSONArray.parseArray(order.getPointGoodsData2(),MonthData.class);
                    for (MonthData data : subsidyCustomerFace.getPointGoodsData2()) {
                        boolean isHave = false;
                        for (MonthData monthData : list) {
                            if(data.getText().equals(monthData.getText())){
                                monthData.setAddValue(monthData.getAddValue()+data.getAddValue());
                                isHave = true;
                                break;
                            }
                        }
                        if(!isHave){
                            list.add(data);
                        }
                    }
                    order.setPointGoodsData2(JSONObject.toJSONString(list));
                }else if(CollectionUtils.isNotEmpty(subsidyCustomerFace.getPointGoodsData2())){
                    order.setPointGoodsData2(JSONObject.toJSONString(subsidyCustomerFace.getPointGoodsData2()));
                }

                if(StringUtils.isNotEmpty(order.getPointCountData()) && CollectionUtils.isNotEmpty(subsidyCustomerFace.getPointCountData())){
                    List<MonthData> list =JSONArray.parseArray(order.getPointCountData(),MonthData.class);
                    List<MonthData> nowList =subsidyCustomerFace.getPointCountData();
                    int t = 0;
                    if(list.get(0).getText().equals(nowList.get(nowList.size()-1).getText())){
                        t = 1;
                    }
                    for (int i = 0; i < nowList.size(); i++) {
                        if(t ==nowList.size()){
                            break;
                        }
                        nowList.get(i).setAddValue(nowList.get(i).getAddValue()+list.get(t).getAddValue());
                        nowList.get(i).setUseValue(nowList.get(i).getUseValue()+list.get(t).getUseValue());
                        t++;
                    }
                    order.setPointCountData(JSONObject.toJSONString(nowList));
                }else if(CollectionUtils.isNotEmpty(subsidyCustomerFace.getPointCountData())){
                    order.setPointCountData(JSONObject.toJSONString(subsidyCustomerFace.getPointCountData()));
                }

                if(StringUtils.isNotEmpty(order.getPointMonthData()) && CollectionUtils.isNotEmpty(subsidyCustomerFace.getPointMonthData())){
                    List<MonthData> list =JSONArray.parseArray(order.getPointMonthData(),MonthData.class);
                    List<MonthData> nowList =subsidyCustomerFace.getPointMonthData();
                    int t = 0;
                    if(list.get(0).getText().equals(nowList.get(nowList.size()-1).getText())){
                        t = 1;
                    }
                    for (int i = 0; i < nowList.size(); i++) {
                        if(t ==nowList.size()){
                            break;
                        }
                        nowList.get(i).setAddValue(nowList.get(i).getAddValue()+list.get(t).getAddValue());
                        nowList.get(i).setUseValue(nowList.get(i).getUseValue()+list.get(t).getUseValue());
                        t++;
                    }
                    order.setPointMonthData(JSONObject.toJSONString(nowList));
                }else if(CollectionUtils.isNotEmpty(subsidyCustomerFace.getPointMonthData())){
                    order.setPointMonthData(JSONObject.toJSONString(subsidyCustomerFace.getPointMonthData()));
                }
            }
        }
    }

    private List<SubsidyCustomerFace> getMerchantIntegralFace(List<Integer> operatorIds,List<ListParams> categoryList){
        List<SubsidyCustomerFace> returnList = Lists.newArrayList();
        List<IntegralTransaction> transList = Lists.newArrayList();
        List<Product> products = Lists.newArrayList();
        for (Integer operatorId : operatorIds) {
            transList.addAll(baseMapper.integralTransactionList(dbName,operatorId));
            products.addAll(baseMapper.queryIntegralProduct(dbName,operatorId));
        }
        List<StationMerchant> stationMerchantList =  baseMapper.getStationMerchantList(dbName);
        List<IntegralProduct> productList = baseMapper.integralProductList(dbName);
        List<StationMerchant> stationList = stationMerchantList.stream().filter(s->s.getStatus().equals(1) && !s.getType().equals(18) && s.getStreet() != null && s.getCountry() != null && s.getCity() != null).collect(Collectors.toList());
        List<ListParams> categoryFilterList = categoryList.stream().filter(c->c.getKey().equals(1)).collect(Collectors.toList());

        //按照街道分组
        Map<Integer,List<StationMerchant>> stationStreetMaps = stationList.stream().collect(Collectors.groupingBy(StationMerchant::getStreet));
        fillStationData(stationStreetMaps,returnList,3,productList,categoryFilterList,products,transList);
        //按照区分组
        Map<Integer,List<StationMerchant>> stationCountryMaps = stationList.stream().collect(Collectors.groupingBy(StationMerchant::getCountry));
        fillStationData(stationCountryMaps,returnList,2,productList,categoryFilterList,products,transList);
        //按照市分组
        Map<Integer,List<StationMerchant>> stationCityMaps = stationList.stream().collect(Collectors.groupingBy(StationMerchant::getCity));
        fillStationData(stationCityMaps,returnList,1,productList,categoryFilterList,products,transList);
        log.info("---客户积分处理结束---");
        return returnList;
    }

    private void fillStationData(Map<Integer,List<StationMerchant>> maps, List<SubsidyCustomerFace> returnList,Integer source,
                                 List<IntegralProduct> productList,List<ListParams> categoryList,List<Product> products,
                                 List<IntegralTransaction> transList){
        for (Integer integer : maps.keySet()) {
            List<StationMerchant> csList = maps.get(integer);
            SubsidyCustomerFace face = new SubsidyCustomerFace();
            face.setAreaId(integer);
            face.setPointStation(csList.size());
            List<MonthData> dataList = Lists.newArrayList();
            for (StationMerchant dto : csList) {
                MonthData monthData = new MonthData();
                monthData.setText(dto.getName());
                monthData.setAddValue(productList.stream().filter(p->p.getMerchantId().equals(dto.getId())).count());
                if(monthData.getAddValue()>0L){
                    dataList.add(monthData);
                }
            }
            //积分商品统计
            dataList = dataList.stream().sorted(Comparator.comparing(MonthData::getAddValue).reversed()).collect(Collectors.toList());
            if(dataList.size() >=5){
                face.setGoodsData(dataList.subList(0,5));
            }else{
                face.setGoodsData(dataList);
            }

            List<Integer> supplierIds = csList.stream().filter(s->s.getSupplierId() != null).map(s->s.getSupplierId()).distinct().collect(Collectors.toList());
            List<Product> pList = products.stream().filter(p->supplierIds.contains(p.getProviderId())).collect(Collectors.toList());
            List<MonthData> pDataList = Lists.newArrayList();
            for (ListParams params : categoryList) {
                MonthData monthData = new MonthData();
                monthData.setText(params.getName());
                Long val = 0L;
                for (Product product : pList) {
                    if(product.getParentCategoryId().equals(params.getId().longValue())){
                        val++;
                    }
                }
                if(val>0L){
                    monthData.setAddValue(val);
                    pDataList.add(monthData);
                }
            }
            //消分商品统计
            face.setGoodsData2(pDataList);

            switch(source){
                case 1:
                    //按区域分组
                    Map<Integer,List<StationMerchant>> countryMaps = csList.stream().collect(Collectors.groupingBy(StationMerchant::getCountry));
                    List<MonthData> countryList = Lists.newArrayList();
                    for (Integer country : countryMaps.keySet()) {
                        List<StationMerchant> list = countryMaps.get(country);
                        MonthData monthData = new MonthData();
                        monthData.setText(countryMaps.get(country).get(0).getCountryName());
                        monthData.setAddValue(Long.parseLong(String.valueOf(list.size())));
                        countryList.add(monthData);
                    }
                    countryList = countryList.stream().sorted(Comparator.comparing(MonthData::getAddValue).reversed()).collect(Collectors.toList());
                    if(countryList.size() >=5){
                        face.setProviderData(countryList.subList(0,5));
                    }else{
                        face.setProviderData(countryList);
                    }
                    break;
                case 2:
                    //按街道分组
                    Map<Integer,List<StationMerchant>> streetMaps = csList.stream().collect(Collectors.groupingBy(StationMerchant::getStreet));
                    List<MonthData> streetList = Lists.newArrayList();
                    for (Integer street : streetMaps.keySet()) {
                        List<StationMerchant> list = streetMaps.get(street);
                        MonthData monthData = new MonthData();
                        monthData.setText(streetMaps.get(street).get(0).getStreetName());
                        monthData.setAddValue(Long.parseLong(String.valueOf(list.size())));
                        streetList.add(monthData);
                    }
                    streetList = streetList.stream().sorted(Comparator.comparing(MonthData::getAddValue).reversed()).collect(Collectors.toList());
                    if(streetList.size() >=5){
                        face.setProviderData(streetList.subList(0,5));
                    }else{
                        face.setProviderData(streetList);
                    }
                    break;
                case 3:
                    //按商户名称
                    List<MonthData> nameList = Lists.newArrayList();
                    for (StationMerchant dto : csList) {
                        MonthData monthData = new MonthData();
                        monthData.setText(dto.getName());
                        nameList.add(monthData);
                    }
                    if(nameList.size() >=5){
                        face.setProviderData(nameList.subList(0,5));
                    }else{
                        face.setProviderData(nameList);
                    }
                    break;
            }

            List<Integer> ids = csList.stream().map(c->c.getId()).collect(Collectors.toList());
            Map<Integer,List<IntegralTransaction>> transMaps = transList.stream().filter(t->ids.contains(t.getMerchantId())).collect(Collectors.groupingBy(IntegralTransaction::getMerchantId));
            List<MonthData> dataList2 = Lists.newArrayList();
            for (Integer tran : transMaps.keySet()) {
                List<IntegralTransaction> trans = transMaps.get(tran);
                MonthData data = new MonthData();
                data.setText(trans.get(0).getMerchantName());
                Long val = 0L;
                for (IntegralTransaction transaction : trans) {
                    val += transaction.getIntegral() * transaction.getNum();
                }
                data.setAddValue(val);
                dataList2.add(data);
            }
            //积分商品个数统计
            dataList2 = dataList2.stream().sorted(Comparator.comparing(MonthData::getAddValue).reversed()).collect(Collectors.toList());
            if(dataList2.size() >=5){
                face.setPointGoodsData(dataList2.subList(0,5));
            }else{
                face.setPointGoodsData(dataList2);
            }
            returnList.add(face);

        }
    }

    private void changeIntegral(Map<Integer, List<Order>> maps,List<Integer> operatorIds,List<ListParams> categoryList) {
        List<SubsidyCustomerFace> customerFaceList = this.getMerchantIntegralFace(operatorIds,categoryList);
        for (SubsidyCustomerFace subsidyCustomerFace : customerFaceList) {
            List<Order> orders = maps.get(subsidyCustomerFace.getAreaId());
            if(orders == null || orders.isEmpty()){
                continue;
            }
            for (Order order : orders) {
                //积分相关
                order.setPointStation(subsidyCustomerFace.getPointStation());
                if(CollectionUtils.isNotEmpty(subsidyCustomerFace.getPointGoodsData())){
                    order.setPointGoodsData(JSONObject.toJSONString(subsidyCustomerFace.getPointGoodsData()));
                }
                if(CollectionUtils.isNotEmpty(subsidyCustomerFace.getProviderData())){
                    order.setProviderData(JSONObject.toJSONString(subsidyCustomerFace.getProviderData()));
                }
                if(CollectionUtils.isNotEmpty(subsidyCustomerFace.getGoodsData())){
                    order.setGoodsData(JSONObject.toJSONString(subsidyCustomerFace.getGoodsData()));
                }
                if(CollectionUtils.isNotEmpty(subsidyCustomerFace.getGoodsData2())){
                    order.setGoodsData2(JSONObject.toJSONString(subsidyCustomerFace.getGoodsData2()));
                }
            }
        }
    }

    private List<OrderStatisticsData> getOrderStatisticsDataList(List<Integer> ids,DateParams dateParams,List<ListParams> categoryList){
        List<OrderStatisticsData> returnList = Lists.newArrayList();
        List<OrderIntegrationData> list = Lists.newArrayList();

        for (Integer id : ids) {
            QueryWrapper queryWrapper = new QueryWrapper<>();
            if(dateParams.getStartDate() != null){
                queryWrapper.ge("o.finish_time",dateParams.getStartDate());
            }
            if(dateParams.getEndDate() != null){
                queryWrapper.lt("o.finish_time",dateParams.getEndDate());
            }
            //获取已完成的服务工单
            list.addAll(baseMapper.queryOrderIntegrationData(id,dbName,queryWrapper));
        }


        Map<Integer,List<ListParams>> categoryMap = categoryList.stream().collect(Collectors.groupingBy(ListParams::getId));
        //按照市统计
        Map<Integer,List<OrderIntegrationData>> cityMaps = list.stream().collect(Collectors.groupingBy(OrderIntegrationData::getCityId));
        //按照区统计
        Map<Integer,List<OrderIntegrationData>> countryMaps = list.stream().collect(Collectors.groupingBy(OrderIntegrationData::getCountryId));
        //按照街道统计
        Map<Integer,List<OrderIntegrationData>> streetMaps = list.stream().collect(Collectors.groupingBy(OrderIntegrationData::getStreetId));
        for (Integer integer : cityMaps.keySet()) {
            integrationData(returnList,cityMaps.get(integer),integer,categoryMap);
        }
        for (Integer integer : countryMaps.keySet()) {
            integrationData(returnList,countryMaps.get(integer),integer,categoryMap);
        }
        for (Integer integer : streetMaps.keySet()) {
            integrationData(returnList,streetMaps.get(integer),integer,categoryMap);
        }

        return returnList;
    }

    private void integrationData(List<OrderStatisticsData> returnList,List<OrderIntegrationData> orderList,
                                 Integer areaId,Map<Integer,List<ListParams>> categoryMap){
        OrderStatisticsData data = new OrderStatisticsData();
        data.setAreaId(areaId);
        List<Long> visitNumList = orderList.stream().map(o->o.getCustomerId()).distinct().collect(Collectors.toList());
        data.setVisitNum(visitNumList.size());
       /* List<OrderIntegrationData> visitOrderList = orderList.stream().filter(o->o.getVisitStatus().equals(1)).collect(Collectors.toList());
        BigDecimal visitRate = new BigDecimal(visitOrderList.size()).divide(new BigDecimal(orderList.size()),4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal(100.0)).setScale(2,BigDecimal.ROUND_HALF_UP);*/
        data.setVisitRate(new BigDecimal(100));
        if(data.getVisitNum()>0){
            List<Long> satisfactionList = orderList.stream().filter(v->v.getResult().equals(1)).map(o->o.getOrderId()).collect(Collectors.toList());
            data.setSatisfactionNum(satisfactionList.size());
            List<Long> qualifiedList = orderList.stream().filter(v->v.getQualified().equals(1)).map(o->o.getOrderId()).collect(Collectors.toList());
            //BigDecimal qualifiedRate = new BigDecimal(qualifiedList.size()).divide(new BigDecimal(orderList.size()),4,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal(100.0)).setScale(2,BigDecimal.ROUND_HALF_UP);
            data.setQualifiedNum(qualifiedList.size());
        }else{
            data.setSatisfactionNum(0);
            data.setQualifiedNum(0);
        }

        data.setOrderNum(orderList.size());

        List<OrderIntegrationData> monthOrderList = orderList.stream()
                .filter(o-> DateUtil.isIn(o.getFinishTime(), com.poteviohealth.cgp.common.utils.DateUtils.getFirstDayOfMonth(new Date()), com.poteviohealth.cgp.common.utils.DateUtils.getLastDayOfMonth(new Date())))
                .collect(Collectors.toList());
        data.setOrderNumMonth(monthOrderList.size());
        Map<String, String> dateMap = com.poteviohealth.cgp.common.utils.DateUtils.getWeekDate();
        try {
            Date monday = com.poteviohealth.cgp.common.utils.DateUtils.startOfDay(com.alibaba.excel.util.DateUtils.parseDate(dateMap.get("mondayDate")));
            Date sunday = com.poteviohealth.cgp.common.utils.DateUtils.endOfDay(com.alibaba.excel.util.DateUtils.parseDate(dateMap.get("sundayDate")));
            List<OrderIntegrationData> weekOrderList = orderList.stream().filter(o->DateUtil.isIn(o.getFinishTime(),monday,sunday)).collect(Collectors.toList());
            data.setOrderNumWeek(weekOrderList.size());
        } catch (ParseException e) {
            e.printStackTrace();
        }


        List<OrderIntegrationData> dayOrderList = orderList.stream()
                .filter(o->DateUtil.isIn(o.getFinishTime(), com.poteviohealth.cgp.common.utils.DateUtils.startOfDay(new Date()), com.poteviohealth.cgp.common.utils.DateUtils.endOfDay(new Date())))
                .collect(Collectors.toList());
        data.setOrderNumDay(dayOrderList.size());

        //服务类型统计
        List<OrderServiceTypeDTO> typeList = Lists.newArrayList();
        Map<Integer,List<OrderIntegrationData>> orderCategoryMaps = orderList.stream().collect(Collectors.groupingBy(OrderIntegrationData::getProductCategoryId));

        Map<Integer,Integer> maps = Maps.newHashMap();
        for (Integer integer : orderCategoryMaps.keySet()) {
            List<ListParams> list = categoryMap.get(integer);
            if(list != null && !list.isEmpty()){
                ListParams listParent = categoryMap.get(list.get(0).getKey()).get(0);
                if(maps.containsKey(listParent.getId())){
                    maps.put(listParent.getId(),maps.get(listParent.getId())+orderCategoryMaps.get(integer).size());
                }else{
                    maps.put(listParent.getId(),orderCategoryMaps.get(integer).size());
                }
            }
        }
        DecimalFormat df = new DecimalFormat("#0.00");
        if(!maps.isEmpty()){
            Integer sum =  maps.values().stream().mapToInt(Integer::intValue).sum();
            for (Integer integer : maps.keySet()) {
                OrderServiceTypeDTO dto = new OrderServiceTypeDTO();
                dto.setId(integer);
                dto.setCount(maps.get(integer));
                dto.setName(categoryMap.get(integer).get(0).getName());
                if(sum == 0){
                    dto.setRate("0");
                }else{
                    dto.setRate(df.format((dto.getCount().doubleValue()/sum)*100.0));
                }
                typeList.add(dto);
            }
            typeList = typeList.stream().sorted(Comparator.comparing(OrderServiceTypeDTO::getCount).reversed()).collect(Collectors.toList());
        }
        if(typeList.size()>=5){
            data.setServiceTypeList(JSON.toJSONString(typeList.subList(0,5)));
        }else{
            data.setServiceTypeList(JSON.toJSONString(typeList));
        }

        returnList.add(data);
    }

    private void changeOrder(Map<Integer, List<Order>> maps,DateParams dateParams,List<Integer> operatorIds,List<ListParams> categoryList) {
        Calendar calendar = Calendar.getInstance();
        calendar.setTime(dateParams.getEndDate());
        DecimalFormat df = new DecimalFormat("#0.00");
        //更新工单相关数据
        List<OrderStatisticsData> orderList = this.getOrderStatisticsDataList(operatorIds,dateParams,categoryList);
        for (OrderStatisticsData orderStatisticsData : orderList) {
            List<Order> orders = maps.get(orderStatisticsData.getAreaId());
            if(orders == null || orders.isEmpty()){
                continue;
            }
            for (Order order : orders) {
                if(order.getVisitNum() == null){
                    order.setVisitNum(0);
                }
                if(order.getOrderNum() == null){
                    order.setOrderNum(0);
                }
                if(order.getSatisfactionRate() == null){
                    order.setSatisfactionRate(new BigDecimal("0.00"));
                }
                if(order.getQualifiedRate() == null){
                    order.setQualifiedRate(new BigDecimal("0.00"));
                }
                BigDecimal satisfaction = order.getSatisfactionRate().multiply(new BigDecimal(order.getOrderNum())).divide(new BigDecimal("100.0"),2,BigDecimal.ROUND_HALF_UP);
                BigDecimal qualified = order.getQualifiedRate().multiply(new BigDecimal(order.getOrderNum())).divide(new BigDecimal("100.0"),2,BigDecimal.ROUND_HALF_UP);
                order.setOrderNum(order.getOrderNum()+orderStatisticsData.getOrderNum());
                order.setVisitNum(order.getVisitNum()+orderStatisticsData.getVisitNum());
                order.setVisitRate(orderStatisticsData.getVisitRate());
                if(order.getOrderNum().equals(0)){
                    order.setSatisfactionRate(new BigDecimal("0.00"));
                    order.setQualifiedRate(new BigDecimal("0.00"));
                }else{
                    BigDecimal addSatisfaction = satisfaction.add(new BigDecimal(orderStatisticsData.getSatisfactionNum()));
                    if(order.getOrderNum() == null || order.getOrderNum().equals(0)){
                        order.setSatisfactionRate(new BigDecimal("0.00"));
                        order.setQualifiedRate(new BigDecimal("0.00"));
                    }else{
                        order.setSatisfactionRate(addSatisfaction.multiply(new BigDecimal("100.0")).divide(new BigDecimal(order.getOrderNum()),2,BigDecimal.ROUND_HALF_UP).setScale(2,BigDecimal.ROUND_HALF_UP));
                        if(order.getSatisfactionRate().compareTo(new BigDecimal(100))>0){
                            order.setSatisfactionRate(new BigDecimal(100));
                        }
                        BigDecimal addQualified = qualified.add(new BigDecimal(orderStatisticsData.getQualifiedNum()));
                        order.setQualifiedRate(addQualified.divide(new BigDecimal(order.getOrderNum()),2,BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100.0")).setScale(2,BigDecimal.ROUND_HALF_UP));
                        if(order.getQualifiedRate().compareTo(new BigDecimal(100))>0){
                            order.setQualifiedRate(new BigDecimal(100));
                        }
                    }
                 }
                if(calendar.get(Calendar.DAY_OF_MONTH) == 1 && calendar.get(Calendar.HOUR_OF_DAY) == 0){
                    //每月1日0点清零
                    order.setOrderNumMonth(0);
                }else{
                    order.setOrderNumMonth((order.getOrderNumMonth() == null ?0:order.getOrderNumMonth())+orderStatisticsData.getOrderNumMonth());
                }
                if (calendar.get(Calendar.DAY_OF_WEEK) == Calendar.MONDAY && calendar.get(Calendar.HOUR_OF_DAY) == 0) {
                    //每周一0点清零
                    order.setOrderNumWeek(0);
                }else{
                    order.setOrderNumWeek((order.getOrderNumWeek()==null?0:order.getOrderNumWeek())+orderStatisticsData.getOrderNumWeek());
                }
                if(calendar.get(Calendar.HOUR_OF_DAY) == 0){
                    //每天0点清零
                    order.setOrderNumDay(0);
                }else{
                    order.setOrderNumDay((order.getOrderNumDay()==null?0:order.getOrderNumDay())+orderStatisticsData.getOrderNumDay());
                }

                if(StringUtils.isEmpty(order.getServiceTypeList())){
                    order.setServiceTypeList(orderStatisticsData.getServiceTypeList());
                }else if(StringUtils.isNotEmpty(orderStatisticsData.getServiceTypeList())){
                    List<OrderServiceTypeDTO> list =JSONArray.parseArray(order.getServiceTypeList(),OrderServiceTypeDTO.class);
                    List<OrderServiceTypeDTO> dataList = JSONArray.parseArray(orderStatisticsData.getServiceTypeList(),OrderServiceTypeDTO.class);
                    for (OrderServiceTypeDTO orderServiceTypeDTO : dataList) {
                        boolean have = false;
                        for (OrderServiceTypeDTO dto : list) {
                            if(dto.getId().equals(orderServiceTypeDTO.getId())){
                                dto.setCount(dto.getCount()+orderServiceTypeDTO.getCount());
                                have = true;
                                break;
                            }
                        }
                        if(!have){
                            list.add(orderServiceTypeDTO);
                        }
                    }
                    Long sum = list.stream().mapToLong(o->o.getCount()).sum();
                    for (OrderServiceTypeDTO dto : list) {
                        dto.setRate(df.format((dto.getCount().doubleValue()/sum)*100.0));
                    }
                }
            }
        }
    }

    public static void main(String[] args) {
        SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        Calendar calendar = Calendar.getInstance();
        try {
            calendar.setTime(df.parse("2024-03-05 00:00:24"));
        } catch (ParseException e) {
            e.printStackTrace();
        }
        System.out.println(calendar.get(Calendar.DAY_OF_WEEK));
        System.out.println(calendar.get(Calendar.HOUR_OF_DAY));

    }
}