package cn.lili.modules.promotion.serviceimpl;

import cn.hutool.json.JSONArray;
import cn.hutool.json.JSONUtil;
import cn.lili.cache.Cache;
import cn.lili.cache.CachePrefix;
import cn.lili.common.enums.PromotionTypeEnum;
import cn.lili.common.enums.ResultCode;
import cn.lili.common.exception.ServiceException;
import cn.lili.common.properties.RocketmqCustomProperties;
import cn.lili.common.security.AuthUser;
import cn.lili.modules.member.service.MemberService;
import cn.lili.modules.promotion.entity.dos.Coupon;
import cn.lili.modules.promotion.entity.dos.CouponActivity;
import cn.lili.modules.promotion.entity.dos.CouponActivityItem;
import cn.lili.modules.promotion.entity.dos.MemberCoupon;
import cn.lili.modules.promotion.entity.dto.CouponActivityDTO;
import cn.lili.modules.promotion.entity.dto.CouponActivityTrigger;
import cn.lili.modules.promotion.entity.enums.*;
import cn.lili.modules.promotion.entity.vos.CouponActivityItemVO;
import cn.lili.modules.promotion.entity.vos.CouponActivityVO;
import cn.lili.modules.promotion.mapper.CouponActivityMapper;
import cn.lili.modules.promotion.service.*;
import cn.lili.modules.promotion.tools.PromotionTools;
import cn.lili.trigger.enums.DelayTypeEnums;
import cn.lili.trigger.interfaces.TimeTrigger;
import cn.lili.trigger.message.CouponActivityMessage;
import cn.lili.trigger.model.TimeExecuteConstant;
import cn.lili.trigger.model.TimeTriggerMsg;
import cn.lili.trigger.util.DelayQueueTools;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

/**
 * 优惠券活动业务层实现
 *
 * @author Bulbasaur
 * @since 2021/5/20 6:10 下午
 */
@Service
@Slf4j
public class CouponActivityServiceImpl extends AbstractPromotionsServiceImpl<CouponActivityMapper, CouponActivity> implements CouponActivityService {

    @Autowired
    private CouponService couponService;
    @Autowired
    private MemberCouponService memberCouponService;
    @Autowired
    private CouponActivityItemService couponActivityItemService;


    @Autowired
    private MemberCouponSignService memberCouponSignService;

    @Autowired
    private MemberService memberService;


    @Autowired
    private Cache<List<CouponActivityVO>> cache;
    /**
     * 延时任务
     */
    @Autowired
    private TimeTrigger timeTrigger;
    /**
     * RocketMQ
     */
    @Autowired
    private RocketmqCustomProperties rocketmqCustomProperties;

    @Override
    public CouponActivityVO getCouponActivityVO(String couponActivityId) {
        CouponActivity couponActivity = this.getById(couponActivityId);
        return new CouponActivityVO(couponActivity, couponActivityItemService.getCouponActivityItemListVO(couponActivityId));
    }


    @Override
    public void specify(CouponActivity couponActivity) {

        //如果开始时间为空，则表示活动关闭
        if (couponActivity.getStartTime() == null) {
            return;
        }

        TimeTriggerMsg timeTriggerMsg = new TimeTriggerMsg(TimeExecuteConstant.COUPON_ACTIVITY_EXECUTOR,
                couponActivity.getStartTime().getTime(),
                CouponActivityMessage.builder().couponActivityId(couponActivity.getId()).build(),
                DelayQueueTools.wrapperUniqueKey(DelayTypeEnums.COUPON_ACTIVITY, couponActivity.getId()),
                rocketmqCustomProperties.getPromotionTopic());
        //发送促销活动开始的延时任务
        timeTrigger.addDelay(timeTriggerMsg);
    }


    @Override
    @Transactional(rollbackFor = Exception.class)
    public void specifyCoupon(String couponActivityId) {

        //获取优惠券活动
        CouponActivity couponActivity = this.getById(couponActivityId);
        //获取活动优惠券发送范围
        List<Map<String, Object>> member = this.getMemberList(couponActivity);

        //如果指定会员发券，则当下直接进行发送，如果是全体会员发券，则变更为用户登录首页进行请求发券
        //PS:即不主动发券，需要用户在活动时间内登录自动领取优惠券，类似美团、饿了么 的发放方式
        if (couponActivity.getActivityScope().equals(CouponActivitySendTypeEnum.DESIGNATED.name())) {
            //会员拆成多个小组进行发送
            List<List<Map<String, Object>>> memberGroup = new ArrayList<>();

            //循环分组
            for (int i = 0; i < (member.size() / 100 + (member.size() % 100 == 0 ? 0 : 1)); i++) {
                int endPoint = Math.min((100 + (i * 100)), member.size());
                memberGroup.add(member.subList((i * 100), endPoint));
            }

            //优惠优惠券活动的优惠券列表
            List<CouponActivityItem> couponActivityItems = couponActivityItemService.getCouponActivityList(couponActivity.getId());
            //发送优惠券
            for (List<Map<String, Object>> memberList : memberGroup) {
                sendCoupon(memberList, couponActivityItems);
            }
        }
    }

    /**
     * 初始化促销字段
     *
     * @param promotions 促销实体
     */
    @Override
    public void initPromotion(CouponActivity promotions) {
        super.initPromotion(promotions);
        if (promotions instanceof CouponActivityDTO) {
            CouponActivityDTO couponActivityDTO = (CouponActivityDTO) promotions;
            //如果有会员，则写入会员信息
            if (couponActivityDTO.getMemberDTOS() != null && !couponActivityDTO.getMemberDTOS().isEmpty()) {
                couponActivityDTO.setActivityScopeInfo(JSONUtil.toJsonStr(couponActivityDTO.getMemberDTOS()));
            }
        }
    }

    /**
     * 检查优惠券活动参数
     *
     * @param couponActivity 优惠券活动实体
     */
    @Override
    public void checkPromotions(CouponActivity couponActivity) {
        if (couponActivity instanceof CouponActivityDTO) {
            CouponActivityDTO couponActivityDTO = (CouponActivityDTO) couponActivity;
            //指定会员判定
            if (couponActivity.getActivityScope().equals(CouponActivitySendTypeEnum.DESIGNATED.name()) && couponActivityDTO.getMemberDTOS().isEmpty()) {
                throw new ServiceException(ResultCode.COUPON_ACTIVITY_MEMBER_ERROR);
            }
            // 检查优惠券
            this.checkCouponActivityItem(couponActivityDTO.getCouponActivityItems());
        }

    }

    /**
     * 更新优惠券活动商品信息
     *
     * @param couponActivity 优惠券活动实体
     * @return 是否更新成功
     */
    @Override
    @Transactional(rollbackFor = {Exception.class})
    public boolean updatePromotionsGoods(CouponActivity couponActivity) {
        boolean result = super.updatePromotionsGoods(couponActivity);
        if (couponActivity instanceof CouponActivityDTO && !PromotionsStatusEnum.CLOSE.name().equals(couponActivity.getPromotionStatus()) && PromotionsScopeTypeEnum.PORTION_GOODS.name().equals(couponActivity.getScopeType())) {
            CouponActivityDTO couponActivityDTO = (CouponActivityDTO) couponActivity;
            //创建优惠券活动子列表
            for (CouponActivityItem couponActivityItem : couponActivityDTO.getCouponActivityItems()) {
                couponActivityItem.setActivityId(couponActivityDTO.getId());
            }
            // 更新优惠券活动项信息
            result = couponActivityItemService.saveBatch(couponActivityDTO.getCouponActivityItems());
        }
        return result;
    }

    /**
     * 更新优惠券活动信息到商品索引
     *
     * @param couponActivity 促销实体
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public void updateEsGoodsIndex(CouponActivity couponActivity) {


        switch (CouponActivityTypeEnum.valueOf(couponActivity.getCouponActivityType())) {

            // 精准发券 则立即发放
            case SPECIFY:
                this.specify(couponActivity);
                this.resetCache(couponActivity.getCouponActivityType());
                break;
            //其他活动则是缓存模块，根据缓存中的优惠券活动信息来确认发放优惠券测略
            case INVITE_NEW:
            case AUTO_COUPON:
            case REGISTERED:
                this.resetCache(couponActivity.getCouponActivityType());
                break;
        }

    }

    @Override
    public List<MemberCoupon> trigger(CouponActivityTrigger couponActivityTrigger) {
        //获取当前正在进行的优惠券活动
        List<CouponActivityVO> couponActivities = currentCouponActivity(couponActivityTrigger.getCouponActivityTypeEnum().name());


        /**
         * 自动发送优惠券则需要补足日志
         */
        if (couponActivityTrigger.getCouponActivityTypeEnum().equals(CouponActivityTypeEnum.AUTO_COUPON) || couponActivityTrigger.getCouponActivityTypeEnum().equals(CouponActivityTypeEnum.SPECIFY)) {
            couponActivities = memberCouponSignService.receiveCoupon(couponActivities);
        }


        //优惠券发放列表
        log.info("当前用户的优惠券活动信息:{}", couponActivityTrigger);
        log.info("当前进行的优惠券活动:{}", couponActivities);
        List<CouponActivityItemVO> couponActivityItemVOS = new ArrayList<>();

        //准备发放优惠券活动的列表
        couponActivities.forEach(item -> couponActivityItemVOS.addAll(item.getCouponActivityItems()));

        AuthUser authUser = new AuthUser();
        authUser.setId(couponActivityTrigger.getUserId());
        authUser.setNickName(couponActivityTrigger.getNickName());


        return this.sendCoupon(authUser, couponActivityItemVOS);
    }


    /**
     * 当前促销类型
     *
     * @return 当前促销类型
     */
    @Override
    public PromotionTypeEnum getPromotionType() {
        return PromotionTypeEnum.COUPON_ACTIVITY;
    }

    /**
     * 缓存key生成策略
     *
     * @param couponActivityType 优惠券活动类型
     * @return 缓存key
     */
    private String cacheKey(String couponActivityType) {
        return CachePrefix.CURRENT_COUPON_ACTIVITY.getPrefix() + couponActivityType;
    }

    /**
     * 当前进行的活动
     *
     * @return 当前进行的活动列表
     */
    private List<CouponActivityVO> currentCouponActivity() {
        return currentCouponActivity(CouponActivityTypeEnum.AUTO_COUPON.name());
    }

    /**
     * 当前进行的活动
     *
     * @return 当前进行的活动列表
     */
    private List<CouponActivityVO> currentCouponActivity(String couponActivityTypeEnum) {
        //获取缓存中的活动
        List<CouponActivityVO> couponActivityList = cache.get(cacheKey(couponActivityTypeEnum));
        if (couponActivityList == null) {
            return ongoingActivities(resetCache(couponActivityTypeEnum));
        }
        return ongoingActivities(couponActivityList);
    }

    /**
     * 从生效的活动优惠券中，过滤出正在进行的活动列表
     *
     * @param activityVOS
     * @return
     */
    private List<CouponActivityVO> ongoingActivities(List<CouponActivityVO> activityVOS) {
        if (activityVOS == null || activityVOS.isEmpty()) {
            return new ArrayList<>();
        }
        return activityVOS.stream().filter(item -> {
            return item.getPromotionStatus().equals(PromotionsStatusEnum.START.name());
        }).collect(Collectors.toList());
    }

    /**
     * 重写缓存中的活动优惠券信息
     */
    private List<CouponActivityVO> resetCache(String couponActivityType) {

        LambdaQueryWrapper<CouponActivity> lambdaQueryWrapper = new LambdaQueryWrapper<>();

        //如果结束时间大于当前时间，则表示有效
        lambdaQueryWrapper.gt(CouponActivity::getEndTime, new Date());
        //发送策略
        lambdaQueryWrapper.eq(CouponActivity::getActivityScope, CouponActivitySendTypeEnum.ALL);
        //活动类型
        lambdaQueryWrapper.eq(CouponActivity::getCouponActivityType, couponActivityType);

        //查询出结果，缓存后返回
        List<CouponActivity> couponActivities = list(lambdaQueryWrapper);

        List<CouponActivityVO> couponActivityVOS = new ArrayList<>();
        for (CouponActivity couponActivity : couponActivities) {
            couponActivityVOS.add(new CouponActivityVO(couponActivity, couponActivityItemService.getCouponActivityItemListVO(couponActivity.getId())));
        }

        cache.put(cacheKey(couponActivityType), couponActivityVOS);
        return couponActivityVOS;
    }

    /**
     * 定向发送优惠券
     *
     * @param memberList          用户列表
     * @param couponActivityItems 优惠券列表
     */
    private void sendCoupon(List<Map<String, Object>> memberList, List<CouponActivityItem> couponActivityItems) {

        for (Map<String, Object> map : memberList) {
            AuthUser authUser = new AuthUser();
            authUser.setId(map.get("id").toString());
            authUser.setNickName(map.get("nick_name").toString());

            sendCoupon(authUser, couponActivityItems);

        }
    }

    /**
     * 给当前用户发送优惠券
     * 1.循环优惠券列表
     * 2.判断优惠券每个会员发送数量
     * 3.记录优惠券发送数量
     *
     * @param authUser            发送目标用户
     * @param couponActivityItems 优惠券列表
     */
    private List<MemberCoupon> sendCoupon(AuthUser authUser, List<? extends CouponActivityItem> couponActivityItems) {

        //最终优惠券列表
        List<MemberCoupon> finalCoupons = new ArrayList<>();

        //循环优惠券赠送列表
        for (CouponActivityItem couponActivityItem : couponActivityItems) {
            //获取优惠券
            Coupon coupon = couponService.getById(couponActivityItem.getCouponId());
            //判断优惠券是否存在
            if (coupon != null) {
                //循环优惠券的领取数量
                int activitySendNum = couponActivityItem.getNum();

                List<MemberCoupon> memberCouponList = new ArrayList<>();
                for (int i = 1; i <= activitySendNum; i++) {
                    MemberCoupon memberCoupon = new MemberCoupon(coupon);
                    memberCoupon.setMemberId(authUser.getId());
                    memberCoupon.setMemberName(authUser.getNickName());
                    memberCoupon.setMemberCouponStatus(MemberCouponStatusEnum.NEW.name());
                    memberCoupon.setPlatformFlag(PromotionTools.PLATFORM_ID.equals(coupon.getStoreId()));
                    memberCouponList.add(memberCoupon);
                }

                finalCoupons.addAll(memberCouponList);
                //批量添加优惠券
                memberCouponService.saveBatch(memberCouponList);
                //添加优惠券已领取数量
                couponService.receiveCoupon(couponActivityItem.getCouponId(), memberCouponList.size());
            } else {
                log.error("赠送优惠券失败,当前优惠券不存在:" + couponActivityItem.getCouponId());
            }
        }
        if (finalCoupons.isEmpty()) {
            return new ArrayList<>();
        }
        return finalCoupons;

    }

    /**
     * 获取优惠券的范围范围
     * 此方法用于精准发券
     *
     * @param couponActivity 优惠券活动
     * @return 获取优惠券的会员列表
     */
    private List<Map<String, Object>> getMemberList(CouponActivity couponActivity) {
        //判断优惠券的发送范围，获取会员列表

        List<String> ids = new ArrayList<>();
        if (JSONUtil.isJsonArray(couponActivity.getActivityScopeInfo())) {
            JSONArray array = JSONUtil.parseArray(couponActivity.getActivityScopeInfo());
            ids = array.toList(Map.class).stream().map(i -> i.get("id").toString()).collect(Collectors.toList());
        }
        return memberService.listFieldsByMemberIds("id,nick_name", ids);
    }

    /**
     * 检查优惠券
     *
     * @param couponActivityItems 优惠券列表
     */
    private void checkCouponActivityItem(List<CouponActivityItem> couponActivityItems) {
        //优惠券数量判定
        if (couponActivityItems.isEmpty()) {
            throw new ServiceException(ResultCode.COUPON_ACTIVITY_ITEM_ERROR);
        } else if (couponActivityItems.size() > 10) {
            throw new ServiceException(ResultCode.COUPON_ACTIVITY_ITEM_MUST_NUM_ERROR);
        } else {
            for (CouponActivityItem item : couponActivityItems) {
                if (item.getNum() == null || item.getNum() <= 0) {
                    throw new ServiceException(ResultCode.COUPON_ACTIVITY_ITEM_NUM_ERROR);
                }
                if (item.getNum() > 2) {
                    throw new ServiceException(ResultCode.COUPON_ACTIVITY_ITEM_NUM_MAX_VALUE_2);
                }
            }
        }
    }
}