package com.xzx.gc.system.service;

import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.StrUtil;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.xzx.gc.entity.SysStorage;
import com.xzx.gc.model.admin.StorageModel;
import com.xzx.gc.model.admin.SysStorageApiModel;
import com.xzx.gc.system.mapper.OrderMapper;
import com.xzx.gc.system.mapper.OrderStorageInfoMapper;
import com.xzx.gc.system.mapper.PartnerGaodeMapper;
import com.xzx.gc.system.mapper.SysStorageMapper;
import com.xzx.gc.util.DoubleUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

@Service
@Transactional
public class SysStorageService {

    @Autowired
    private SysStorageMapper sysStorageMapper;

    @Autowired
    private CityPartnerService cityPartnerService;

    @Autowired
    private PartnerGaodeMapper partnerGaodeMapper;

    @Autowired
    private OrderStorageInfoMapper orderStorageInfoMapper;

    @Autowired
    private OrderMapper orderMapper;

    public SysStorage findById(Integer id){
        return sysStorageMapper.selectByPrimaryKey(id);
    }


    /**
     * 添加仓库
     *
     * @param storageModel
     * @return
     */
    public int addSysStorageApi(SysStorageApiModel storageModel) {

        if(StrUtil.isBlank(storageModel.getPartnerId())){
            List<String> list = cityPartnerService.queryPartnerByCurrent();
            if(CollUtil.isNotEmpty(list)){
                storageModel.setPartnerId(CollUtil.getFirst(list));
            }
        }

        storageModel.setCreateTime(DateUtil.now());
        return sysStorageMapper.addSysStorageApi(storageModel);
    }

    /**
     * 修改仓库
     *
     * @param storageModel
     * @return
     */
    public int updateSysStorageApi(SysStorageApiModel storageModel) {
        SysStorage sysStorage=new SysStorage();
        BeanUtil.copyProperties(storageModel,sysStorage);
        return sysStorageMapper.updateByPrimaryKeySelective(sysStorage);
//        return sysStorageMapper.updateSysStorageApi(storageModel);
    }

    /**
     * 删除仓库
     *
     * @param storageModel
     * @return
     */
    public int delSysStorageApi(SysStorageApiModel storageModel) {
        return sysStorageMapper.delSysStorageApi(storageModel);
    }


    public Map<String, Object> querySysStorageList(SysStorageApiModel storageModel) {
//        List<String> partnerIds = new ArrayList<>();

        if(StrUtil.isBlank(storageModel.getPartnerId())){
            List<String> list = cityPartnerService.queryPartnerByCurrent();
            if(CollUtil.isNotEmpty(list)){
                storageModel.setPartnerId(CollUtil.getFirst(list));
            }
        }



        Map<String, Object> m = new HashMap<>();
        PageHelper.startPage(storageModel.getPage(),storageModel.getLimit());
        List<SysStorageApiModel> list = sysStorageMapper.querySysStorageApiList(storageModel);
        PageInfo<SysStorageApiModel> pageInfo=new PageInfo<>(list);

        m.put("data", list);
        m.put("count", pageInfo.getTotal());
        m.put("code", 0);
        return m;
    }


    public List<Map<String, Object>> querySysStrangeList(){
        List<String> partnerIds = cityPartnerService.queryPartnerByCurrent();
        List<Map<String, Object>> list;
        if(null!=partnerIds&&partnerIds.size()>0){
            List<String> townIds = partnerGaodeMapper.queryTownIdsByPartnerIdList(partnerIds);
            list = sysStorageMapper.querySysStrangeList(townIds);

        }else{
            list = sysStorageMapper.querySysStrangeList(null);
        }

        return list;
    }

    public Map<String,Object> querySysStorageListData(StorageModel storageModel) {
        List<String> partnerIds = new ArrayList<>();
        if(null!=storageModel.getPartnerId()&&!"".equals(storageModel.getPartnerId())){
            partnerIds.add(storageModel.getPartnerId());
        }else{
            partnerIds = cityPartnerService.queryPartnerByCurrent();
        }
        if(null!=partnerIds&&partnerIds.size()>0){
            String partnerId = partnerIds.get(0);
            List<String> townIds = cityPartnerService.queryTownIdsByPartnerId(partnerId);
            storageModel.setTownIds(townIds);
        }
        Map<String,Object> result = new HashMap<>();
        PageHelper.startPage(storageModel.getPage(),storageModel.getLimit());
        List<Map<String,Object>> list = sysStorageMapper.querySysStorageList(storageModel);
        PageInfo<Map<String,Object>> pageInfo = new PageInfo<>(list);
        BigDecimal allWeight = new BigDecimal("0");
        BigDecimal allMoney = new BigDecimal("0");
        //相隔的天数 ，查询日均
        int dayNum = orderStorageInfoMapper.queryDayDiff(storageModel);
        for (Map<String,Object> map:list) {
            StorageModel pModel = new StorageModel();
            String id = map.get("id").toString();
            map.put("areaname",map.get("areaName"));
            map.put("storagename",map.get("storageName"));
            pModel.setSysStorageId(id);
            pModel.setStartTime(storageModel.getStartTime());
            pModel.setEndTime(storageModel.getEndTime());
            pModel.setPartnerIds(partnerIds);
            Map<String,Object> rMap = orderStorageInfoMapper.querySysStorageAll(pModel);
            List<String>  allOrderNumBySsId= orderStorageInfoMapper.sysStorageOrderNum(pModel);
            BigDecimal allOrderNum = new BigDecimal("0") ;
            for (String orderIds:allOrderNumBySsId) {
                String[] ossid = orderIds.split(",");
                allOrderNum = allOrderNum.add(new BigDecimal(ossid.length));
            }
            map.put("orderNum",allOrderNum);
            if(null!=rMap){
                allWeight = allWeight.add(new BigDecimal(rMap.get("storageWeight").toString()));
                allMoney =allMoney.add(new BigDecimal(rMap.get("storageMoney").toString()));
                BigDecimal storageWeight = new BigDecimal(rMap.get("storageWeight").toString());
                storageWeight = storageWeight.divide(new BigDecimal("1000"),6,RoundingMode.HALF_UP);
                BigDecimal storageMoney = new BigDecimal(rMap.get("storageMoney").toString());
                storageMoney = storageMoney.divide(new BigDecimal("10000"),5,RoundingMode.HALF_UP);
                BigDecimal recycleweight = new BigDecimal(rMap.get("recycleWeight").toString());
                recycleweight = recycleweight.divide(new BigDecimal("1000"),6,RoundingMode.HALF_UP);
                BigDecimal recyclemoney = new BigDecimal(rMap.get("recycleMoney").toString());
                recyclemoney = recyclemoney.divide(new BigDecimal("10000"),5,RoundingMode.HALF_UP);
                map.put("storageWeight",DoubleUtil.roundSix(storageWeight.toString()));
                map.put("storageMoney",DoubleUtil.roundFive(storageMoney.toString()));
                map.put("recycleWeight",DoubleUtil.roundSix(recycleweight.toString()));
                map.put("recycleMoney",DoubleUtil.roundFive(recyclemoney.toString()));
                //日均重量
                BigDecimal sw = new BigDecimal(rMap.get("storageWeight").toString());
                if(dayNum>0){
                    BigDecimal dayw = sw.divide(new BigDecimal(dayNum),6, RoundingMode.HALF_UP);
                    map.put("dayStorageWeight",dayw.divide(new BigDecimal("1000"),6,RoundingMode.HALF_UP));
                }else{
                    sw =sw.divide(new BigDecimal("1000"),6,RoundingMode.HALF_UP);
                    map.put("dayStorageWeight",DoubleUtil.roundThree(sw.toString()));
                }
                //日均金额
                BigDecimal sm = new BigDecimal(rMap.get("storageMoney").toString());
                if(dayNum>0){
                    BigDecimal daym = sm.divide(new BigDecimal(dayNum),5,RoundingMode.HALF_UP);
                    map.put("dayStorageMoney",daym.divide(new BigDecimal("10000"),5,RoundingMode.HALF_UP));
                }else{
                    map.put("dayStorageMoney",sm.divide(new BigDecimal("10000"),5,RoundingMode.HALF_UP));
                }

            }
        }
        if(dayNum==0){
            dayNum=1;
        }
        BigDecimal alldayw = allWeight.divide(new BigDecimal(dayNum),6,RoundingMode.HALF_UP);
        BigDecimal alldaym = allMoney.divide(new BigDecimal(dayNum),5,RoundingMode.HALF_UP);
        allWeight = allWeight.divide(new BigDecimal("1000"),6,RoundingMode.HALF_UP);
        alldayw = alldayw.divide(new BigDecimal("1000"),6,RoundingMode.HALF_UP);
        alldaym = alldaym.divide(new BigDecimal("10000"),5,RoundingMode.HALF_UP);
        allMoney = allMoney.divide(new BigDecimal("10000"),5,RoundingMode.HALF_UP);
        //int count = dao.querySysStorageCount(storageModel);
        result.put("count",pageInfo.getTotal());
        result.put("code",0);
        result.put("data",list);
        result.put("allWeight",DoubleUtil.roundSix(allWeight.toString()));
        result.put("allMoney",DoubleUtil.roundFive(allMoney.toString()));
        result.put("allDayWeight",DoubleUtil.roundSix(alldayw.toString()));
        result.put("allDayMoney",DoubleUtil.roundFive(alldaym.toString()));
        return result;
    }


    public Map<String,Object> querySysStorageDetail(StorageModel storageModel) {
        Map<String,Object> result = new HashMap<>();
        List<Map<String,String>> weekOrMonthList = new ArrayList<>();
        List<Map<String,String>> weekOrMonthImgList = new ArrayList<>();
        //相隔天数
        int dayNum = orderStorageInfoMapper.queryDayDiff(storageModel);
        Map<String,Object> allRMap = sysStorageMapper.querySysStorageAll(storageModel);

        BigDecimal allWeight = new BigDecimal(allRMap.get("storageWeight").toString());
        BigDecimal  allMoney = new BigDecimal(allRMap.get("storageMoney").toString());
        BigDecimal alldayw = new BigDecimal("0");
        BigDecimal alldaym = new BigDecimal("0");

        if(dayNum>0){
            alldayw = allWeight.divide(new BigDecimal(dayNum),2,RoundingMode.HALF_UP);
            alldaym = allMoney.divide(new BigDecimal(dayNum),2,RoundingMode.HALF_UP);
        }
        String am = allMoney.divide(new BigDecimal("10000"),2, RoundingMode.HALF_UP).toString();
        String aw = allWeight.divide(new BigDecimal("1000"),3, RoundingMode.HALF_UP).toString();
        String adm = alldaym.divide(new BigDecimal("10000"),2, RoundingMode.HALF_UP).toString();
        String adw = alldayw.divide(new BigDecimal("1000"),3, RoundingMode.HALF_UP).toString();

        result.put("allWeight",DoubleUtil.roundThree(aw));
        result.put("allMoney",DoubleUtil.roundTwo(am));
        result.put("alldayw",DoubleUtil.roundThree(adw));
        result.put("alldaym",DoubleUtil.roundTwo(adm));

        List<Map<String,Object>> weekOrderList = new ArrayList<>();
        List<Map<String,Object>> weekMoneyAndWeightList = new ArrayList<>();
        List<Map<String,Object>> detailImage = new ArrayList<>();
        if(null!=storageModel.getTimeType()&&!"".equals(storageModel.getTimeType())){
            if(storageModel.getTimeType().equals("week")){
                weekOrMonthList = com.xzx.gc.util.DateUtil.query12WeekStartTimeAndEndTime();
            }else{
                weekOrMonthList = com.xzx.gc.util.DateUtil.query12MonthStartTimeAndEndTime();
            }
            for (Map<String,String> map:weekOrMonthList) {
                String startTime = map.get("startTime");
                String endTime = map.get("endTime");
                if(map.get("storageWeight")!=null){
                    String storageweight = DoubleUtil.roundThree(map.get("storageWeight"));
                    map.put("storageWeight",storageweight);
                }
                if(map.get("recycleWeight")!=null){
                    String recycleweight = DoubleUtil.roundThree(map.get("recycleWeight"));
                    map.put("recycleWeight",recycleweight);
                }



                //周订单数
                weekOrderList = getWeekOrderList(startTime,endTime,storageModel.getSysStorageId(),weekOrderList);
                //周金额（入库金额，订单金额,入库重量，订单重量）
                weekMoneyAndWeightList = getWeekMoneyAndWeightList(startTime,endTime,storageModel.getSysStorageId(),weekMoneyAndWeightList);
            }
        }else{
            weekOrMonthList = com.xzx.gc.util.DateUtil.query12WeekStartTimeAndEndTime();
            for (Map<String,String> map:weekOrMonthList) {
                String startTime = map.get("startTime");
                String endTime = map.get("endTime");
                if(map.get("storageWeight")!=null){
                    String storageweight = DoubleUtil.roundThree(map.get("storageWeight"));
                    map.put("storageweight",storageweight);
                }
                if(map.get("recycleWeight")!=null){
                    String recycleweight = DoubleUtil.roundThree(map.get("recycleWeight"));
                    map.put("recycleweight",recycleweight);
                }
                //周订单数
                weekOrderList = getWeekOrderList(startTime,endTime,storageModel.getSysStorageId(),weekOrderList);
                //周金额（入库金额，订单金额,入库重量，订单重量）
                weekMoneyAndWeightList = getWeekMoneyAndWeightList(startTime,endTime,storageModel.getSysStorageId(),weekMoneyAndWeightList);
            }
        }
        Map<String,String> lastMap = new HashMap<>();
        if(null!=storageModel.getImageType()&&!"".equals(storageModel.getImageType())) {
            if (storageModel.getImageType().equals("week")) {
                weekOrMonthImgList = com.xzx.gc.util.DateUtil.query12WeekStartTimeAndEndTime();
                lastMap = weekOrMonthImgList.get(0);
            } else {
                weekOrMonthImgList = com.xzx.gc.util.DateUtil.query12MonthStartTimeAndEndTime();
                lastMap = weekOrMonthImgList.get(0);
            }
        }else{
            weekOrMonthImgList = com.xzx.gc.util.DateUtil.query12WeekStartTimeAndEndTime();
            lastMap = weekOrMonthImgList.get(0);
        }
        detailImage = getSysStorageTypeName(storageModel.getSysStorageId(), lastMap.get("startTime"),lastMap.get("endTime"),null);
        for (Map<String,Object> obj:weekMoneyAndWeightList) {
            if(obj.get("storageWeight")!=null){
                String storageweight = DoubleUtil.roundThree(obj.get("storageWeight").toString());
                obj.put("storageweight",storageweight);
            }
            if(obj.get("storageMoney")!=null){
                String storageMoney = DoubleUtil.roundThree(obj.get("storageMoney").toString());
                obj.put("storagemoney",storageMoney);
            }
            if(obj.get("recycleMoney")!=null){
                String recycleMoney = DoubleUtil.roundThree(obj.get("recycleMoney").toString());
                obj.put("recyclemoney",recycleMoney);
            }
            if(obj.get("recycleWeight")!=null){
                String recycleWeight = DoubleUtil.roundThree(obj.get("recycleWeight").toString());
                obj.put("recycleweight",recycleWeight);
            }
        }
        result.put("weekOrMonthOrderList",weekOrderList);
        result.put("weekOrMonthMoneyAndWeightList",weekMoneyAndWeightList);
        result.put("detailImage",detailImage);

        return result;
    }

    /**
     * 按照仓库图表统计周订单数
     * @param startTime
     * @param endTime
     * @param sysStorageId
     * @param weekOrderList
     * @return
     */
    private List<Map<String,Object>> getWeekOrderList(String startTime,String endTime,String sysStorageId,List<Map<String,Object>> weekOrderList){
        Map<String,Object> paramMap = new HashMap<>();
        //订单量 入库、订单重量 入库、订单金额
        StorageModel storageModel1 = new StorageModel();
        storageModel1.setStartTime(startTime);
        storageModel1.setEndTime(endTime);
        storageModel1.setSysStorageId(sysStorageId);
        List<String> orderIdBySysStorageId = orderStorageInfoMapper.sysStorageOrderNum(storageModel1);
        int orderNum = 0 ;
        for (String orderIds:orderIdBySysStorageId) {
            orderNum = orderIds.split(",").length;
        }
        String[] startStr = startTime.split(" ");
        String[] endStr = endTime.split(" ");
        paramMap.put("startTime",startStr[0]);
        paramMap.put("endTime",endStr[0]);
        paramMap.put("orderNum",orderNum);
        weekOrderList.add(paramMap);
        return weekOrderList;
    }

    private List<Map<String,Object>> getWeekMoneyAndWeightList(String startTime,String endTime,String sysStorageId,List<Map<String,Object>> weekOrderList) {
        //入库、订单重量 入库、订单金额
        StorageModel storageModel2 = new StorageModel();
        storageModel2.setStartTime(startTime);
        storageModel2.setEndTime(endTime);
        storageModel2.setSysStorageId(sysStorageId);
        Map<String,Object> rMap = sysStorageMapper.querySysStorageAll(storageModel2);

        String[] startStr = startTime.split(" ");
        String[] endStr = endTime.split(" ");
        rMap.put("startTime",startStr[0]);
        rMap.put("endTime",endStr[0]);
        weekOrderList.add(rMap);
        return weekOrderList;
    }

    private List<Map<String,Object>> getSysStorageTypeName(String sysStorageId,String startTime,String endTime,String typeName){
        List<Map<String,Object>> resultMap = new ArrayList<>();
        StorageModel storageModel1 = new StorageModel();
        storageModel1.setStartTime(startTime);
        storageModel1.setEndTime(endTime);
        storageModel1.setSysStorageId(sysStorageId);
        List<String> orderIdBySysStorageId = orderStorageInfoMapper.sysStorageOrderNum(storageModel1);
        List<String> orderIds = new ArrayList<>();
        for (String ids:orderIdBySysStorageId) {
            String[] orderIdsTemp = ids.split(",");
            for (String orderId:orderIdsTemp) {
                orderIds.add(orderId);
            }
        }
        List<Map<String,Object>> list = new ArrayList<>();
        if(orderIds!=null&&orderIds.size()>0){
            list = orderMapper.getSysStorageTypeName(orderIds,null,null,typeName);
        }
        //总金额
        BigDecimal totalMoney = new BigDecimal("0");
        for (Map<String,Object> map:list) {
            totalMoney = totalMoney.add(new BigDecimal(map.get("money").toString()));
        }
        //查询占比
        for (Map<String,Object> map:list) {
            BigDecimal rate = new BigDecimal(map.get("money").toString()).divide(totalMoney,2,RoundingMode.HALF_UP);
            map.put("rate",rate.multiply(new BigDecimal("100")).toString()+"%");
            BigDecimal money = new BigDecimal(map.get("money").toString());
            BigDecimal weight = new BigDecimal(map.get("weight").toString());
            money = money.divide(new BigDecimal("10000"),2, RoundingMode.HALF_UP);
            weight = weight.divide(new BigDecimal("1000"),3, RoundingMode.HALF_UP);
            map.put("weight",DoubleUtil.roundThree(weight.toString()));
            map.put("money",DoubleUtil.roundTwo(money.toString()));
        }
        Map<String,Object> imageData = new HashMap<>();
        if(null!=totalMoney){
            totalMoney =  totalMoney.divide(new BigDecimal("10000"),2, RoundingMode.HALF_UP);
        }

        imageData.put("totalMoney",DoubleUtil.roundTwo(totalMoney.toString()));
        imageData.put("data",list);
        resultMap.add(imageData);
        return resultMap;
    }
}