package cn.lili.listener;

import cn.lili.cache.Cache;
import cn.lili.common.enums.ResultCode;
import cn.lili.common.exception.ServiceException;
import cn.lili.elasticsearch.EsSuffix;
import cn.lili.modules.lmk.domain.dto.VideoEsUpdateDTO;
import cn.lili.modules.lmk.domain.entity.*;
import cn.lili.modules.lmk.domain.es.VideoIndex;
import cn.lili.modules.lmk.enums.general.PrizeDistributeStatusEnum;
import cn.lili.modules.lmk.enums.general.PrizeGrantStatusEnums;
import cn.lili.modules.lmk.enums.general.PrizeNumberUseEnum;
import cn.lili.modules.lmk.enums.general.PrizeStatusEnum;
import cn.lili.modules.lmk.service.*;
import cn.lili.modules.promotion.service.MemberCouponService;
import cn.lili.rocketmq.tags.VideoTagsEnum;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.common.message.MessageExt;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Component;

/**
 * 抽奖活动
 *
 * @author paulG
 * @since 2020/12/9
 **/
@Component
@Slf4j
@RocketMQMessageListener(topic = "${lili.data.rocketmq.prize-topic}", consumerGroup = "${lili.data.rocketmq.prize-group}")
public class PrizeMessageListener implements RocketMQListener<MessageExt> {
    @Autowired
    private PrizeDrawService prizeDrawService;
    @Autowired
    private PrizeRecordService prizeRecordService;
    @Autowired
    private PrizeNumberService prizeNumberService;
    @Autowired
    private PrizeGrantRecordService prizeGrantRecordService;
    @Autowired
    private MemberCouponService memberCouponService;
    @Autowired
    private  RedissonClient redissonClient;

    private final static String PRIZE_GRANT_KEY = "prize_grant_key:";
    @Override
    public void onMessage(MessageExt messageExt) {
        try {
            String msg = new String(messageExt.getBody());
            log.info("收到了抽奖信息{}",msg);
            switch (PrizeStatusEnum.valueOf(messageExt.getTags())) {
                case WIN:
                    PrizeRecord prizeRecord = JSON.parseObject(msg, PrizeRecord.class);
                    RLock lock = redissonClient.getLock(PRIZE_GRANT_KEY + prizeRecord.getId());
                    try {
                        lock.lock();
                        PrizeRecord source = prizeRecordService.getById(prizeRecord.getId());
                        //当前中奖记录不存在直接返回
                        if (source == null) {
                            log.info("没有对应的中奖{}", prizeRecord.getId());
                            return;
                        }
                        //奖品不是待发放状态直接返回
                        if (!PrizeDistributeStatusEnum.WAIT.name().equals(source.getDistributeStatus())) {
                            log.info("发放状态不是待发放{}", prizeRecord.getId());
                            return;
                        }
                        //抽奖卷是否一致
                        if (!prizeRecord.getPrizeNumId().equals(source.getPrizeNumId())) {
                            log.info("抽奖卷id不一致{}", prizeRecord.getId());
                            return;
                        }
                        PrizeDraw prizeDraw = prizeDrawService.getById(prizeRecord.getPrizeId());
                        if (prizeDraw == null) {
                            log.info("当前奖品不存在{}", prizeRecord.getId());
                            return;
                        }
                        PrizeNumber number = prizeNumberService.getById(prizeRecord.getPrizeNumId());
                        if (number == null) {
                            log.info("当前抽奖券不存在{}", prizeRecord.getId());
                            return;
                        }
                        if (!PrizeNumberUseEnum.USED.name().equals(number.getUseStatus())) {
                            log.info("当前抽奖券不是已使用状态{}", prizeRecord.getId());
                            return;
                        }
                        PrizeGrantRecord grantRecord = prizeGrantRecordService.getById(prizeRecord.getId());
                        //当前奖品已经记录不需要发放
                        if (grantRecord != null) {
                            log.info("当前中奖记录已经记录{}", prizeRecord.getId());
                            return;
                        }
                        grantRecord = new PrizeGrantRecord();
                        //设置id相同使用主键防住重复发放
                        grantRecord.setId(prizeRecord.getId());
                        grantRecord.setUserId(prizeRecord.getUserId());
                        grantRecord.setNickName(prizeRecord.getNickName());
                        grantRecord.setActivityId(prizeRecord.getPrizeActivityId());
                        grantRecord.setActivityName(prizeRecord.getPrizeActivityName());
                        grantRecord.setPrizeNumId(prizeRecord.getPrizeNumId());
                        grantRecord.setPrizeName(prizeRecord.getPrizeName());
                        grantRecord.setPrizeContent(prizeRecord.getPrizeContent());
                        grantRecord.setGrantStatus(PrizeGrantStatusEnums.SUCCESS.name());
                        grantRecord.setPrizeId(prizeRecord.getPrizeId());
                        source.setDistributeStatus(PrizeDistributeStatusEnum.SUCCESS.name());
                        prizeGrantRecordService.save(grantRecord);
                        try {
                            memberCouponService.receiveCoupon(prizeDraw.getCouponId(), prizeRecord.getUserId() + "", prizeRecord.getNickName());
                        } catch (Exception e) {
                            log.error("奖品发放失败",e);
                            log.error("奖品发放失败失败的id是{}", prizeRecord.getId());
                            //报错就直接发放失败
                            source.setDistributeStatus(PrizeDistributeStatusEnum.FAILED.name());
                            grantRecord.setGrantStatus(PrizeGrantStatusEnums.FAILED.name());
                            if (e instanceof ServiceException) {
                                ResultCode resultCode = ((ServiceException) e).getResultCode();
                                if (ResultCode.COUPON_NOT_EXIST.equals(resultCode)) {
                                    grantRecord.setDes(ResultCode.COUPON_NOT_EXIST.message());
                                } else if (ResultCode.COUPON_RECEIVE_ERROR.equals(resultCode)) {
                                    grantRecord.setDes(ResultCode.COUPON_RECEIVE_ERROR.message());
                                } else if (ResultCode.COUPON_NUM_INSUFFICIENT_ERROR.equals(resultCode)) {
                                    grantRecord.setDes(ResultCode.COUPON_NUM_INSUFFICIENT_ERROR.message());
                                } else if (ResultCode.COUPON_LIMIT_ERROR.equals(resultCode)) {
                                    grantRecord.setDes(ResultCode.COUPON_LIMIT_ERROR.message());
                                }
                            }
                        }
                        prizeGrantRecordService.updateById(grantRecord);
                        //更新中奖记录表中的状态
                        prizeRecordService.updateById(source);
                        break;
                    } finally {
                        if (lock.isHeldByCurrentThread()) {
                            lock.unlock();
                        }
                    }
                default:
                    log.error("奖品发放没有匹配的标签");
                    break;
            }
        } catch (Exception e) {
            log.error("奖品发放异常", e);
        }
    }


}