package com.ishop.merchant.service;

import com.ishop.model.po.EbCouponUser;
import com.walker.infrastructure.utils.DateUtils;
import com.walker.infrastructure.utils.StringUtils;
import com.walker.jdbc.service.BaseServiceImpl;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

@Service
public class CouponUserServiceImpl extends BaseServiceImpl {

    /**
     * 更新用户优惠券为“已使用”
     * @param couponIdList 优惠券ID集合
     * @date 2023-07-09
     */
    public void execUpdateUseCoupons(List<Long> couponIdList){
        Map<String, Object> param = new HashMap<>(2);
        param.put("ids", couponIdList);
        this.execute("update eb_coupon_user set status=1 where id in (:ids)", param);
    }

    /**
     * 获取订单可用的优惠券集合。该方法需要优化，感觉写的很丑。
     * @param preOrderNo
     * @param merId
     * @param maxPrice
     * @param date
     * @param uid
     * @param pidList
     * @return
     * @date 2023-07-09
     */
    public List<EbCouponUser> queryListByPreOrderNo(String preOrderNo, Integer merId, Double maxPrice, Long date
            , Long uid, List<Long> pidList){
        Map<String, Object> param = new HashMap<>(2);
        StringBuilder sql = new StringBuilder("select * from eb_coupon_user cu where cu.status = 0");
        if(merId != null){
            sql.append(" and cu.mer_id = :merId");
            param.put("merId", merId);
        }
        sql.append(" and (cu.min_price = 0");
        if(maxPrice != null && maxPrice.doubleValue() > 0){
            sql.append(" or cu.min_price <= :maxPrice");
            param.put("maxPrice", maxPrice);
        }
        sql.append(")");
        if(date != null && date.longValue() > 0){
            sql.append(" and cu.start_time < :date");
            sql.append(" and cu.end_time > :date");
            param.put("date", date);
        }
        if(uid != null && uid.longValue() > 0){
            sql.append(" and cu.uid = :uid");
            param.put("uid", uid);
        }
        sql.append(" and (cu.category = 1 or (cu.category = 2");

        String pidPrimaryKeySql = this.getPidPrimaryKeySql(pidList);
        sql.append(" and ").append(pidPrimaryKeySql).append(" order by cu.id desc");
        log.debug("=========== {}", sql);
        return this.select(sql.toString(), param, new EbCouponUser());
    }

    /**
     * 获取商品拼接sql
     *
     * @param pidList 商品id列表
     */
    private String getPidPrimaryKeySql(List<Long> pidList) {
        List<String> sqlList = new ArrayList<>();
        pidList.forEach(pid -> {
            String sql = pid + " in (select pid from eb_coupon_product where cid = cu.coupon_id)";
            sqlList.add(sql);
        });
        return "( " + org.apache.commons.lang3.StringUtils.join(sqlList, " or ") + ")";
    }

    /**
     * 返回用户拥有的优惠券Map对象，key = 优惠券ID，value = EbCouponUser
     * @param userId
     * @return
     * @date 2023-07-09
     */
    public Map<Integer, EbCouponUser> queryCouponIdAndValue(long userId){
        List<EbCouponUser> list = this.select("select * from eb_coupon_user where uid=?", new Object[]{userId}, new EbCouponUser());
        if(StringUtils.isEmptyList(list)){
            return null;
        }
        Map<Integer, EbCouponUser> map = new HashMap<>();
        for(EbCouponUser info: list){
            map.put(info.getCouponId(), info);
        }
        return map;
    }

    /**
     * 获取用户可用优惠券数量
     * @param userId
     * @return
     * @date 2023-06-30
     */
    public int queryUserCouponCount(long userId){
        EbCouponUser param = new EbCouponUser();
        param.setUid(userId);
        param.setStatus(0);
        List<EbCouponUser> list = this.select(param);
        if(StringUtils.isEmptyList(list)){
            return 0;
        }
        long currentTime = DateUtils.getDateTimeNumber();
        EbCouponUser e = null;
        for(Iterator<EbCouponUser> it = list.iterator(); it.hasNext();){
            e = it.next();
            if(e.getStartTime().longValue() > 0 && e.getEndTime().longValue() > 0){
                if(currentTime < e.getStartTime().longValue() || currentTime > e.getEndTime().longValue()){
                    it.remove();
                    continue;
                }
            }
        }
        return StringUtils.isEmptyList(list)? 0: list.size();
    }

    private static final String SQL_COLLECTION_LIST = "select * from eb_coupon_user where uid=? and status=?";
}