package cn.exrick.xboot.your.schedulings;
import cn.exrick.xboot.your.entity.Area;
import cn.exrick.xboot.your.entity.AreaSection;
import cn.exrick.xboot.your.entity.Customer;
import cn.exrick.xboot.your.entity.OrderTask;
import cn.exrick.xboot.your.service.IAreaSectionService;
import cn.exrick.xboot.your.service.IAreaService;
import cn.exrick.xboot.your.service.ICustomerService;
import cn.exrick.xboot.your.service.IOrderTaskService;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.io.IOException;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
import java.util.List;

//大屏配送分析
@Component
public class StatisticPc2ScheduleImpl {

    @Autowired
    private IAreaService iAreaService;

    @Autowired
    private IAreaSectionService iAreaSectionService;

    @Autowired
    private ICustomerService iCustomerService;

    @Autowired
    private IOrderTaskService iOrderTaskService;

    @Scheduled(cron="0 0 20 * * ?")//每晚8点执行
    public void execute(){
        List<Area> list = iAreaService.list();
        for(Area area:list){
            QueryWrapper<Customer> wrapper = new QueryWrapper<>();
            wrapper.eq("area_id",area.getId());
            int count = iCustomerService.count(wrapper);
            area.setCustomerSum(count);
            iAreaService.saveOrUpdate(area);
        }

        List<AreaSection> list2 = iAreaSectionService.list();
        for(AreaSection areaSection:list2){
            String id = areaSection.getId();
            QueryWrapper<Customer> wrapper = new QueryWrapper<>();
            wrapper.eq("area_section_id",id);
            int count = iCustomerService.count(wrapper);
            areaSection.setCustomerNum(count);

            List<OrderTask> orderTasks = iOrderTaskService.sumTime(id);
            int sum = 0;
            List<Integer> listTime = new ArrayList<>();
            for(OrderTask orderTask:orderTasks){
                sum+=orderTask.getTime();
                listTime.add(orderTask.getTime());
            }

            Collections.sort(listTime);

            double v = (sum * 1.0) / (1000 * 60 * 60) / listTime.size();
            areaSection.setAvgTime((double) Math.round(v * 10) / 10);
            if(listTime.size()>0){
                double v1 = (listTime.get(0) * 1.0) / (1000 * 60 * 60);
                areaSection.setMinTime((double) Math.round(v1 * 10) / 10);

                double v2 = (listTime.get(listTime.size()-1) * 1.0) / (1000 * 60 * 60);
                areaSection.setMaxTime((double) Math.round(v2 * 10) / 10);
            }

            double variance = Variance(listTime);
            areaSection.setStability(variance);
            iAreaSectionService.saveOrUpdate(areaSection);
        }

    }

    public double Variance(List<Integer> x) {
        List<Double> y = new ArrayList<>();
        for(Integer s:x){
            y.add(trans((s*1.0)/(3600*1000)));
        }

        int m = x.size();
        double sum = 0;
        for (int i = 0; i < m; i++) {
            sum += y.get(i);
        }
        double dAve = sum / m;
        double dVar = 0;
        for (int i = 0; i < m; i++) {
            dVar += (y.get(i) - dAve) * (y.get(i) - dAve);
        }
        double v = dVar / m;
        return trans2(v);
    }

    public double trans(double v2){
        return (double) Math.round(v2 * 10) / 10;
    }

    public double trans2(double v2){
        return (double) Math.round(v2 * 100) / 100;
    }
}