package com.ibeetl.admin.console.service;

import cn.hutool.core.collection.CollUtil;
import cn.hutool.json.JSON;
import cn.hutool.json.JSONUtil;
import com.ibeetl.admin.console.dao.CuserConsoleDao;
import com.ibeetl.admin.console.dao.EchartConsoleDao;
import com.ibeetl.admin.console.model.EchartModel;
import com.ibeetl.admin.console.model.ItemRateModel;
import com.ibeetl.admin.console.util.DoubleUtil;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.text.DecimalFormat;
import java.text.SimpleDateFormat;
import java.util.*;

/**
 * 图表数据
 */
@Service
public class EchartResumeService {
    /*static SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH");
    static SimpleDateFormat sdf6 = new SimpleDateFormat("yyyy-MM-dd HH:mm");
    static SimpleDateFormat sdf2 = new SimpleDateFormat("yyyy-MM-dd");
    static SimpleDateFormat sdf3 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    static SimpleDateFormat sdf4 = new SimpleDateFormat("yyyy");
    static SimpleDateFormat sdf5 = new SimpleDateFormat("yyyy-MM");
    @Autowired
    EchartConsoleDao dao;
    @Autowired
    CuserConsoleDao cuserConsoleDao;
    @Autowired
    RedisService redisService;*/
    // @Scheduled(cron = "0 */60 * * * ?")
   /* @Scheduled(cron = "${charsTime}")
    public void index() throws Exception{
        Integer integer = dao.qeuryConfigInfo("ECHAR_X");
        if(integer == null){
            log.info("----------字典值配置ECHAR_X=0--------");
        }

        if(integer == 1){
            System.out.println("======"+"我在这11111");
            // 第一次启动
            Date d = new Date();
            String startTime = sdf6.format(d) + ":00";
            String endTime = sdf6.format(d) + ":59";
            startEchar(startTime, endTime, 1);
            dao.updateConfigInfo("ECHAR_X");
        }else if(integer == 0){
        }
    }
    void startEchar(String startTime, String endTime, int flag){
        log.info("--------统计任务开始执行: {}----------", sdf3.format(new Date()));
        Date d = new Date();
        // String startTime = sdf.format(d) + " :00:00";
        // String endTime = sdf.format(d) + " :59:59";
        System.out.println("===="+startTime+"===="+endTime);
        EchartModel echartModel = moneyEchart(startTime, endTime);
        EchartModel em = userEchart(startTime, endTime);
        echartModel.setUserCount(em.getUserCount());
        em = orderEchart(startTime, endTime);
        echartModel.setOrderCount(em.getOrderCount());
        Map<String,Object> dayCountMap = cuserConsoleDao.queryUserDayCount();
        if(null!=dayCountMap&&null!=dayCountMap.get("userDayCount")){
            echartModel.setVisitCount(Integer.parseInt(dayCountMap.get("userDayCount").toString()));
        }
        List<EchartModel> list = storageEchart(startTime, endTime);
        if(null!=list&&list.size()>0){
            for(EchartModel model : list){
                echartModel.setStorageMoneyCount(model.getStorageMoneyCount());
                echartModel.setStorageWeightCount(model.getStorageWeightCount());
                echartModel.setSysStorageId(model.getSysStorageId());
                if(flag == 0){
                    echartModel.setCreateTime(startTime);
                    echartModel.setDateHours(startTime);
                }else{
                    echartModel.setCreateTime(sdf3.format(d));
                    echartModel.setDateHours(sdf.format(d)+":00:00");
                }
                dao.insertEchart(echartModel);
            }

        }
        log.info("--------统计任务结束: {}----------", sdf3.format(new Date()));
    }*/
    /**
     * 金钱统计
     */
   /* EchartModel moneyEchart(String startTime, String endTime){
        return dao.moneyEchart(startTime, endTime);
    }*/
    /**
     * 用户统计
     */
/*
    EchartModel userEchart(String startTime, String endTime){
        return dao.userEchart(startTime, endTime);
    }
*/
    /**
     * 订单统计
     */
/*
    EchartModel orderEchart(String startTime, String endTime){
        return dao.orderEchart(startTime, endTime);
    }
*/
    /**
     * 库存统计
     */
    /*List<EchartModel> storageEchart(String startTime, String endTime){
        return dao.storageEchart(startTime, endTime);
    }
    Boolean compareDate(String dataNow,String dateRedis){
        if(dateRedis.compareTo(dataNow) <= 0){
            return true;
        }
        return false;
    }
*/
    /**
     * 统计以前的数据
     * 这个方法需要延时执行并且只能执行一次
     */
    // @Scheduled(initialDelay = 1000*60*60*2,fixedRate = 1000*60*60*24)
    /*@Scheduled(cron = "${charsTime}")
    @Transactional(rollbackFor = {})
    void indexed() throws Exception{
        // 获取字典值的数据
        Integer integer = dao.qeuryConfigInfo("ECHAR_FLAG");
        if(integer == null || integer == 0){
            log.info("--------请先配置ECHAR_FLAG的值或此任务已经执行222222--------");
            return;
        }
        // 获取订单里面的第一条数据的时间
        ItemRateModel order = dao.queryOrder();
        if(StringUtils.isEmpty(order.getCreateTime())){
            log.info("-------订单为0,此条件不会执行-------");
            dao.updateConfigInfo("ECHAR_FLAG");
            return;
        }
        // 获取统计表的第一条数据的时间
        ItemRateModel model = dao.queryModel();
        if(model == null){
            return;
        }
        if(StringUtils.isEmpty(model.getCreateTime())){
            model.setCreateTime(sdf3.format(new Date()));
        }

        Calendar calendar = Calendar.getInstance();
        List<ItemRateModel> list = new ArrayList<>();
        while (true){
            calendar.set(Calendar.HOUR_OF_DAY, calendar.get(Calendar.HOUR_OF_DAY)-1);
            String dataNow = sdf3.format(calendar.getTime());
            if(!compareDate(dataNow, order.getCreateTime())){
                log.info("----------获取的时间比订单是小,break---------");
                break;
            }
            ItemRateModel irm = new ItemRateModel();
            irm.setStartTime(sdf.format(calendar.getTime())+":00:00");
            irm.setEndTime(sdf.format(calendar.getTime()) +":59:59");
            list.add(irm);
        }

        log.info("-------统计以前的数据时间集合(老版本)------ {}", list.size());

        for(ItemRateModel im : list){
            startEchar(im.getStartTime(), im.getEndTime(), 0);
        }
        dao.updateConfigInfo("ECHAR_FLAG");
        log.info("----------统计以前的数据完成(老版本)-------");
    }*/
}