package com.xzx.gc.user.service;

import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.convert.Convert;
import com.xzx.gc.common.utils.BusinessUtil;
import com.xzx.gc.entity.WeightItemPrice;
import com.xzx.gc.user.dto.RayaltyDto;
import com.xzx.gc.user.mapper.RebateWeightPriceMapper;
import com.xzx.gc.user.mapper.WeightItemPriceMapper;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import tk.mybatis.mapper.entity.Example;

import java.util.List;

@Service
@Transactional
@Slf4j
public class WeightItemPriceService {

    @Autowired
    private BusinessUtil businessUtil;

    @Autowired
    private WeightItemPriceMapper weightItemPriceMapper;

    /**
     * 查看回收员的提成
     * @param receiver
     * @return
     */
    public RayaltyDto findByReceiver(String receiver){
        RayaltyDto rayaltyDto=new RayaltyDto();

        Example example=new Example(WeightItemPrice.class);
        Example.Criteria criteria = example.createCriteria();
        criteria.andEqualTo("receiver",receiver);
        criteria.andIn("status",CollUtil.newArrayList("1","3"));
        List<WeightItemPrice> select = weightItemPriceMapper.selectByExample(example);
        double sum = select.stream().mapToDouble(x -> Convert.toDouble(x.getSettleMoney(), 0.0)).sum();
        rayaltyDto.setNotPay(businessUtil.changeMoney(String.valueOf(sum)));

//        if(CollUtil.isNotEmpty(select)){
//            Map<String, List<WeightItemPrice>> collect = select.stream().collect(Collectors.groupingBy(WeightItemPrice::getPackageId));
//
//            BigDecimal money=Constants.MONEY_INIT;
//            for (String s : collect.keySet()) {
//                List<WeightItemPrice> weightItemPrices = collect.get(s);
//                RebateWeightPrice weightPrice=new RebateWeightPrice();
//                weightPrice.setPackageId(s);
//                weightPrice.setDelFlag(Convert.toShort(Constants.DEL_NOT_FLAG));
//                List<RebateWeightPrice> weightPrice1 = rebateWeightPriceMapper.select(weightPrice);
//                if(CollUtil.isNotEmpty(weightPrice1)){
//
//                    //得到不同类型的物品的每公斤的提成
//                    Dict dict=Dict.create();
//                    for (RebateWeightPrice rebateWeightPrice : weightPrice1) {
//                        String productType = rebateWeightPrice.getProductType();
//                        String money1 = rebateWeightPrice.getMoney();
//                        dict.put(productType,money1);
//                    }
//
//
//                    //计算总额
//                    for (WeightItemPrice weightItemPrice : weightItemPrices) {
//                        String weight = weightItemPrice.getWeight();
//                        String productType = weightItemPrice.getProductType();
//                        Object o = dict.get(productType);
//                        if(o!=null){
//                            String moneyPer= (String) o;
//                            BigDecimal mul = NumberUtil.mul(Convert.toBigDecimal(weight), Convert.toBigDecimal(moneyPer));
//                            money=NumberUtil.add(money,mul);
//                        }
//                    }
//                }
//
//            }
//
//            if(money.compareTo(BigDecimal.ZERO)>0){
//                rayaltyDto.setNotPay(businessUtil.changeMoney(money.toString()));
//            }
//
//        }

        return rayaltyDto;
    }
}