package cn.lili.modules.statistics.serviceimpl;

import cn.lili.cache.Cache;
import cn.lili.cache.CachePrefix;
import cn.lili.common.enums.ClientTypeEnum;
import cn.lili.common.enums.ResultCode;
import cn.lili.common.exception.ServiceException;
import cn.lili.common.properties.StatisticsProperties;
import cn.lili.common.security.enums.UserEnums;
import cn.lili.common.utils.CurrencyUtil;
import cn.lili.modules.member.entity.vo.MemberDistributionVO;
import cn.lili.modules.statistics.entity.dos.PlatformViewData;
import cn.lili.modules.statistics.entity.dto.StatisticsQueryParam;
import cn.lili.modules.statistics.entity.enums.SearchTypeEnum;
import cn.lili.modules.statistics.entity.vo.OnlineMemberVO;
import cn.lili.modules.statistics.entity.vo.PlatformViewVO;
import cn.lili.modules.statistics.mapper.PlatformViewMapper;
import cn.lili.modules.statistics.service.MemberStatisticsService;
import cn.lili.modules.statistics.service.PlatformViewService;
import cn.lili.modules.statistics.util.StatisticsDateUtil;
import cn.lili.modules.statistics.util.StatisticsSuffix;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.List;

/**
 * 流量统计
 *
 * @author Chopper
 * @version v1.0
 * @since v7.0
 * 2021/1/18 12:07
 */
@Service
public class PlatformViewServiceImpl extends ServiceImpl<PlatformViewMapper, PlatformViewData> implements PlatformViewService {

    /**
     * 在线人数统计
     */
    @Autowired
    private StatisticsProperties statisticsProperties;
    /**
     * 会员
     */
    @Autowired
    private MemberStatisticsService memberStatisticsService;
    /**
     * 缓存
     */
    @Autowired
    private Cache cache;

    @Override
    public Long online() {
        Object object = cache.get(CachePrefix.ONLINE_NUM.getPrefix());

        if (null != object) {
            return (Long) object;
        }
        //这里统计的是有效的accessToken ，如果需要数据精确，需要调整accessToken的有效时间，开发人员建议2小时误差较为合适
        Long num = Long.valueOf(cache.keys(CachePrefix.ACCESS_TOKEN.getPrefix(UserEnums.MEMBER) + "*").size());
        cache.put(CachePrefix.ONLINE_NUM.getPrefix(), num, statisticsProperties.getCurrentOnlineUpdate().longValue());
        return num;
    }

    @Override
    public List<MemberDistributionVO> memberDistribution() {
        Object object = cache.get(CachePrefix.MEMBER_DISTRIBUTION.getPrefix());

        if (null != object) {
            return (List<MemberDistributionVO>) object;
        }
        List<MemberDistributionVO> memberDistributionVOS = memberStatisticsService.distribution();

        //统计总数
        int count = 0;
        for (MemberDistributionVO vo : memberDistributionVOS) {
            count += vo.getNum();
        }
        //初始化数据，填充枚举和比例
        for (MemberDistributionVO vo : memberDistributionVOS) {
            vo.setProportion(CurrencyUtil.div(vo.getNum(), count, 4));
            //客户端填充
            if (StringUtils.isNotEmpty(vo.getClientEnum())) {
                vo.setClientEnum(ClientTypeEnum.valueOf(vo.getClientEnum()).clientName());
            } else {
                vo.setClientEnum(ClientTypeEnum.UNKNOWN.clientName());
            }
        }

        cache.put(CachePrefix.MEMBER_DISTRIBUTION.getPrefix(), memberDistributionVOS);
        return memberDistributionVOS;
    }

    @Override
    public List<OnlineMemberVO> statisticsOnline() {
        Object object = cache.get(CachePrefix.ONLINE_MEMBER.getPrefix());
        List<OnlineMemberVO> result = new ArrayList<>();
        if (object != null) {
            result = (List<OnlineMemberVO>) object;
        }
        return this.initData(result);
    }

    /**
     * 在线会员数据初始化
     *
     * @param source
     * @return
     */
    private List<OnlineMemberVO> initData(List<OnlineMemberVO> source) {
        List<OnlineMemberVO> onlineMemberVOS = new ArrayList<>();

        Calendar calendar = Calendar.getInstance();
        calendar.set(Calendar.MINUTE, 0);
        calendar.set(Calendar.SECOND, 0);
        calendar.set(Calendar.MILLISECOND, 0);

        calendar.set(Calendar.HOUR_OF_DAY, calendar.get(Calendar.HOUR_OF_DAY) - statisticsProperties.getOnlineMember());
        //循环填充数据
        for (int i = 0; i < statisticsProperties.getOnlineMember(); i++) {
            calendar.set(Calendar.HOUR_OF_DAY, calendar.get(Calendar.HOUR_OF_DAY) + 1);
            OnlineMemberVO exitOnlineNum = null;
            for (int j = 0; j < source.size(); j++) {
                if (source.get(j).getDate().equals(calendar.getTime())) {
                    exitOnlineNum = source.get(j);
                }
            }
            if (exitOnlineNum == null) {
                onlineMemberVOS.add(new OnlineMemberVO(calendar.getTime(), 0, 0));
            } else {
                onlineMemberVOS.add(exitOnlineNum);
            }
        }
        return onlineMemberVOS;
    }

    @Override
    public List<PlatformViewVO> list(StatisticsQueryParam queryParam) {
        List<PlatformViewVO> result = new ArrayList<>();

        //查询开始时间和结束时间，用于数据库查询
        Date endTime = null, startTime = null;

        //搜索类型判定，如果不为空，则按照搜索类型进行查询
        if (StringUtils.isNotEmpty(queryParam.getSearchType())) {
            SearchTypeEnum searchTypeEnum = SearchTypeEnum.valueOf(queryParam.getSearchType());
            switch (searchTypeEnum) {
                case TODAY:
                    PlatformViewVO today = new PlatformViewVO();
                    //查询 平台流量
                    if (StringUtils.isEmpty(queryParam.getStoreId())) {
                        //设置PV UV属性
                        String pv = cache.getString(CachePrefix.PV.getPrefix() + StatisticsSuffix.suffix());
                        if (pv == null) {
                            pv = "0";
                        }
                        today.setPvNum(Long.valueOf(pv));
                        today.setUvNum(cache.counter(CachePrefix.UV.getPrefix() + StatisticsSuffix.suffix()).longValue());
                    }
                    //店铺流量
                    else {
                        //设置PV UV属性

                        String pv = cache.getString(CachePrefix.STORE_PV.getPrefix() + StatisticsSuffix.suffix(queryParam.getStoreId()));
                        if (pv == null) {
                            pv = "0";
                        }
                        today.setPvNum(Long.valueOf(pv));
                        today.setUvNum(cache.counter(CachePrefix.STORE_UV.getPrefix() + StatisticsSuffix.suffix(queryParam.getStoreId())).longValue());
                    }
                    today.setDate(new Date());
                    result.add(today);
                    break;
                case YESTERDAY:
                case LAST_SEVEN:
                case LAST_THIRTY: {
                    Date[] dates = StatisticsDateUtil.getDateArray(searchTypeEnum);
                    endTime = dates[1];
                    startTime = dates[0];
                    break;
                }
                default:
                    throw new ServiceException(ResultCode.ERROR);
            }
        } else {
            //根据查询时间来确定查询参数
            Integer year = queryParam.getYear();
            Integer month = queryParam.getMonth();

            Calendar calendar = Calendar.getInstance();
            calendar.set(Calendar.HOUR_OF_DAY, 0);
            calendar.set(Calendar.MINUTE, 0);
            calendar.set(Calendar.SECOND, 0);
            calendar.set(Calendar.MILLISECOND, 0);

            calendar.set(year, month - 1, 1);
            startTime = calendar.getTime();
            calendar.set(year, month, -1);
            endTime = calendar.getTime();
        }
        //时间不为空则按照时间开始数据查询
        if (startTime != null) {
            LambdaQueryWrapper<PlatformViewData> lambdaQueryWrapper = new LambdaQueryWrapper<>();
            lambdaQueryWrapper.between(PlatformViewData::getDate, startTime, endTime);
            lambdaQueryWrapper.eq(PlatformViewData::getStoreId, StringUtils.isEmpty(queryParam.getStoreId()) ?
                    "-1" : queryParam.getStoreId());
            List<PlatformViewData> dataList = this.list(lambdaQueryWrapper);
            result = builderVOS(startTime, endTime, dataList);
        }
        return result;
    }

    @Override
    public Integer countUv(StatisticsQueryParam queryParam) {
        Date[] dates = StatisticsDateUtil.getDateArray(queryParam);
        //获取当前时间
        Calendar calendar = Calendar.getInstance();


        calendar.set(calendar.get(Calendar.YEAR), calendar.get(Calendar.MONTH), calendar.get(Calendar.DAY_OF_MONTH), 0, 0, 0);
        calendar.set(Calendar.MILLISECOND, 0);
        //如果是今天的统计，则从redis 中拿，否则从数据库中拿
        if (dates[0].equals(calendar.getTime())) {
            if (StringUtils.isNotEmpty(queryParam.getStoreId())) {
                return cache.counter(CachePrefix.UV.getPrefix() + StatisticsSuffix.suffix(queryParam.getStoreId())).intValue();
            }
            return cache.counter(CachePrefix.UV.getPrefix() + StatisticsSuffix.suffix()).intValue();
        } else {
            QueryWrapper queryWrapper = new QueryWrapper();
            queryWrapper.between("date", dates[0], dates[1]);
            //根据店铺查询判定，如果有，则店铺查询，如果没有，则根据商家查询
            if (StringUtils.isNotEmpty(queryParam.getStoreId())) {
                queryWrapper.eq("store_id", queryParam.getStoreId());
            } else {
                queryWrapper.eq("store_id", -1);
            }
            return this.baseMapper.count(queryWrapper);
        }
    }

    /**
     * 根据查询条件，创建数据
     *
     * @param startDate
     * @param endDate
     * @param dataList
     * @return
     */
    private List<PlatformViewVO> builderVOS(Date startDate, Date endDate, List<PlatformViewData> dataList) {

        Calendar startTime = Calendar.getInstance();
        startTime.setTime(startDate);

        Calendar endTime = Calendar.getInstance();
        endTime.setTime(endDate);

        List<PlatformViewVO> result = new ArrayList<>();

        //构造所有需要统计展示等流量数据
        List<Date> listDate = new ArrayList<>();
        while (startTime.before(endTime) || startTime.getTime().equals(endTime.getTime())) {
            listDate.add(startTime.getTime());
            startTime.set(Calendar.DAY_OF_MONTH, startTime.get(Calendar.DAY_OF_MONTH) + 1);

        }
        //根据时间集，匹配查询到等数据，构建返回等VO
        listDate.forEach(date -> {
            PlatformViewVO platformViewVO = new PlatformViewVO(date);
            dataList.forEach(platformViewData -> {
                if (platformViewData.getDate().equals(date)) {
                    BeanUtils.copyProperties(platformViewData, platformViewVO);
                }
            });
            //没有匹配到数据库查询的数据，则初始化数据
            result.add(platformViewVO);
        });
        return result;

    }

}