package com.ibeetl.admin.console.service;

import cn.hutool.core.bean.BeanUtil;
import com.ibeetl.admin.console.dao.CuserConsoleDao;
import com.ibeetl.admin.console.dao.StatisConsoleDao;
import com.ibeetl.admin.console.model.PromoterModel;
import com.ibeetl.admin.console.util.DateUtil;
import com.ibeetl.admin.console.util.DoubleUtil;
import org.apache.commons.codec.binary.Base64;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.io.UnsupportedEncodingException;
import java.math.BigDecimal;
import java.util.*;

/**
 * 数据统计
 */
@Service
public class StatisConsoleService {

    @Autowired
    StatisConsoleDao statisConsoleDao;
    @Autowired
    CuserConsoleDao dao;
    final Base64 base64 = new Base64();

    /**
     * 查询用户的经纬度
     */
    public Map<String, Object> queryLatAndLong(){
        Map<String, Object> m = new HashMap<>();
        m.put("data", statisConsoleDao.queryLatAndLong());
        return m;
    }

    /**
     * 查询推广员的一些数据
     * @param promoterModel
     */
    public Map<String, Object> queryPromoterStatis(PromoterModel promoterModel){
        List<PromoterModel> promoterModels = statisConsoleDao.queryPromoterStatis(promoterModel);
        int count = statisConsoleDao.queryPromoterStatisCount(promoterModel);
        Map<String, Object> m = new HashMap<>();
        m.put("data", promoterModels);
        m.put("count", count);
        m.put("code", 0);
        return m;

    }

    /*public Map<String, Object> queryQromoterOrder(PromoterModel promoterModel){

        int count = dao.queryQromoterListCount(promoterModel);
        // 查询订单数据
        List<PromoterModel> list = dao.queryQromoterList(promoterModel);
        for(PromoterModel p : list){
            p.setTurnoverRate("0");
            List<PromoterModel> li = dao.queryQromoterLeven(p.getUserId());
            for(PromoterModel pm : li){
                if(pm.getRegsterType().equals("1")){
                    // 未注册总数
                    if(null!=pm.getCount()){
                        p.setUnregistCount(pm.getCount());
                    }
                }else if(pm.getRegsterType().equals("2")){
                    // 已注册总数
                    if(null!=pm.getCount()){
                        p.setRegistCount(pm.getCount());
                    }
                }else if(pm.getRegsterType().equals("3")){
                    // 已成交总数
                    if(null!=pm.getCount()){
                        p.setOrderCount(pm.getCount());
                        if(null!=p.getRegistCount()){
                            p.setRegistCount(String.valueOf(Integer.parseInt(p.getRegistCount())+Integer.parseInt(pm.getCount())));
                        }else{
                            p.setRegistCount(pm.getCount());
                        }
                    }
                }
            }
            if(null!=p.getOrderCount()&&null!=p.getRegistCount()){
                BigDecimal turnoverRate = new BigDecimal(p.getOrderCount()).divide(new BigDecimal(p.getRegistCount()),3,BigDecimal.ROUND_DOWN);
                p.setTurnoverRate(turnoverRate.multiply(new BigDecimal("100")).toString()+"%");
            }
            PromoterModel pmx = dao.queryPromoterOrderWeightMoney(p.getUserId());
            if(null!=pmx.getOrderWeightCount()){
                p.setOrderWeightCount(DoubleUtil.roundByScale(pmx.getOrderWeightCount(),3));
            }
            if(null!=pmx.getOrderMoneyCount()){
                p.setOrderMoneyCount(DoubleUtil.roundByScale(pmx.getOrderMoneyCount(),2));
            }
        }

        Map<String, Object> m = new HashMap<>();
        m.put("data", list);
        m.put("count", count);
        m.put("code", 0);
        return m;
    }*/
    /**
     * 查询推广员的一些数据
     */
    public Map<String, Object> queryQromoterOrder(PromoterModel promoterModel){
        int pa = promoterModel.getPage();
        pa = (pa - 1) * promoterModel.getLimit();
        promoterModel.setPage(pa);
        if(null!=promoterModel.getStartTime()&&!"".equals(promoterModel.getStartTime())){
            promoterModel.setStartTime(promoterModel.getStartTime()+" 00:00:00");
        }
        if(null!=promoterModel.getEndTime()&&!"".equals(promoterModel.getEndTime())){
            promoterModel.setEndTime(promoterModel.getEndTime()+" 23:59:59");
        }
        List<PromoterModel> promoterModels = new ArrayList<>();
        if(null!=promoterModel.getSortType()&&!"".equals(promoterModel.getSortType())){
            promoterModel.setOrderNumSort(Integer.parseInt(promoterModel.getSortType()));
            promoterModels = statisConsoleDao.queryQromoterOrderOne(promoterModel);
            //用于接收重复的项目片块数据，返回给方法的调用者
            List<List<PromoterModel>> result = new ArrayList<List<PromoterModel>>();
            //用于临时保存重复的项目片块数据
            Map<String, List<PromoterModel>> map = new TreeMap<String, List<PromoterModel>>();

            for (PromoterModel model:promoterModels) {
                PromoterModel newP = new PromoterModel();
                String userId = model.getCreateUserId();
                //判断当前值是否已经在map中存在
                if (map.containsKey(userId)) {
                    List<PromoterModel> hasObj = map.get(userId);
                    //对象拷贝
                    PromoterModel landTarget = new PromoterModel();
                    BeanUtil.copyProperties(model, landTarget);
                    hasObj.add(landTarget);
                    new ArrayList<PromoterModel>().add(landTarget);
                    map.put(userId, hasObj);
                } else {
                    List<PromoterModel> newObj = new ArrayList<PromoterModel>();
                    PromoterModel landTarget = new PromoterModel();
                    BeanUtil.copyProperties(model, landTarget);
                    newObj.add(landTarget);
                    map.put(userId, newObj);
                }
            }
            //取出所有的重复的数据值，存入到result中
            for (Map.Entry<String, List<PromoterModel>> entry : map.entrySet()) {
                result.add(entry.getValue());
            }
            promoterModels = getOneOrMore(promoterModel.getOrderNumSort(),result);

        }else{
            promoterModels = statisConsoleDao.queryQromoterOrder(promoterModel);

        }

        for (PromoterModel model:promoterModels) {
            String orderWeightCount = model.getOrderWeightCount();
            model.setOrderWeightCount(DoubleUtil.roundThree(orderWeightCount));
            model.setOrderMoneyCount(DoubleUtil.roundTwo(model.getOrderMoneyCount()));
            String nickName= model.getNickName();
            if(null!=nickName&&!"".equals(nickName)){
                try {
                    nickName =new String(base64.decode(model.getNickName()), "UTF-8");
                } catch (UnsupportedEncodingException e) {
                    e.printStackTrace();
                }

                model.setNickName(nickName);
            }
        }
        int count=0;
        if(null!=promoterModel.getSortType()&&!"".equals(promoterModel.getSortType())){
            count = promoterModels.size();
            promoterModels = promoterModels.subList(pa,count-pa>promoterModel.getLimit()?pa+promoterModel.getLimit():count);
        }else{
            count = statisConsoleDao.queryQromoterOrderCount(promoterModel);

        }

        Map<String, Object> m = new HashMap<>();
        m.put("data", promoterModels);
        m.put("count", count);
        m.put("code", 0);
        return m;

    }

    private List<PromoterModel> getOneOrMore(int sort,List<List<PromoterModel>> result){
        List<PromoterModel> oneOrMore = new ArrayList<>();
        for (List<PromoterModel> m1List:result) {
            if(m1List.size()>0){
                switch (sort) {
                    case 1:oneOrMore.add(m1List.get(0)); break;
                    case 2:if(m1List.size()>1){ oneOrMore.add(m1List.get(1));} break;
                    case 3:if(m1List.size()>2){oneOrMore.add(m1List.get(2));} break;
                    case 4:if(m1List.size()>3){oneOrMore.add(m1List.get(3));} break;
                    default:
                        break;
                }
            }
        }
        return oneOrMore;
    }
}