绿满筐商城java服务
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
peng
3 天以前 4eeeb59f6c514b61c78aec2acc95cff4807810e1 
 framework/src/main/java/cn/lili/modules/lmk/service/impl/PrizeServiceImpl.java


@@ -5,26 +5,34 @@


import cn.lili.common.properties.RocketmqCustomProperties;


import cn.lili.common.security.AuthUser;


import cn.lili.common.security.context.UserContext;


import cn.lili.common.utils.BeanUtil;


import cn.lili.common.utils.StringUtils;


import cn.lili.modules.lmk.domain.entity.*;


import cn.lili.modules.lmk.domain.form.AddPrizeNumForm;


import cn.lili.modules.lmk.domain.query.PrizeRecordTimeQuery;


import cn.lili.modules.lmk.domain.vo.PrizeDetailVO;


import cn.lili.modules.lmk.domain.vo.PrizeProbabilityVO;


import cn.lili.modules.lmk.domain.vo.PrizeRecordTimeVO;


import cn.lili.modules.lmk.domain.vo.PrizeResultVO;


import cn.lili.modules.lmk.enums.general.*;


import cn.lili.modules.lmk.service.*;


import cn.lili.modules.promotion.entity.dos.Coupon;


import cn.lili.modules.promotion.service.CouponService;


import cn.lili.mybatis.BaseEntity;


import cn.lili.rocketmq.RocketmqSendCallbackBuilder;


import cn.lili.utils.COSUtil;


import com.alibaba.fastjson.JSON;


import com.alibaba.fastjson.JSONObject;


import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;


import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;


import com.baomidou.mybatisplus.core.toolkit.IdWorker;


import com.baomidou.mybatisplus.core.toolkit.Wrappers;


import lombok.RequiredArgsConstructor;


import lombok.extern.slf4j.Slf4j;


import org.apache.rocketmq.spring.core.RocketMQTemplate;


import org.redisson.api.RLock;


import org.redisson.api.RedissonClient;


import org.springframework.beans.BeanUtils;


import org.springframework.data.redis.core.RedisTemplate;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;


@@ -41,6 +49,7 @@


import java.util.function.Function;


import java.util.stream.Collectors;




@Slf4j


@Service


@RequiredArgsConstructor


public class PrizeServiceImpl implements PrizeService {


@@ -56,6 +65,8 @@


    private final RocketmqCustomProperties rocketmqCustomProperties;


    private final RocketMQTemplate rocketMQTemplate;


    private final COSUtil cosUtil;


    private final CouponService couponService;




    @Override


    @Transactional(rollbackFor = Exception.class)


    public Result prize(String prizeId) {


@@ -174,7 +185,7 @@


        prizeRecordTimeQuery.setEndTime(endTime);


        prizeRecordTimeQuery.setRecordActivityId(prizeId);


        prizeRecordListByTime = prizeRecordService.getPrizeRecordListByTime(prizeRecordTimeQuery);


        prizeRecordListByTime.stream().filter(item->{


        prizeRecordListByTime.stream().filter(item -> {


            return item.getActivityPrizeRefId() != null;


        }).forEach(item -> {


            ActivityRefPrize activityRefPrize = canPrizeMap.get(item.getActivityPrizeRefId());


@@ -214,6 +225,12 @@


        }


        BigDecimal max = currentProbability.multiply(BigDecimal.valueOf(100));


        BigDecimal bigDecimal = generateRandom(BigDecimal.ONE, max);


        try {


            log.info("抽奖号码为---------------------------->{}", bigDecimal);


            log.info("抽奖概率集合为------------------------->{}", JSONObject.toJSONString(prizeProbabilityList));


        } catch (Exception e) {


            log.error("打印抽奖信息报错----------------------->", e);


        }


        for (PrizeProbabilityVO prizeProbabilityVO : prizeProbabilityList) {


            BigDecimal minP = prizeProbabilityVO.getProbability()[0][0];


            BigDecimal maxP = prizeProbabilityVO.getProbability()[0][1];


@@ -221,6 +238,31 @@


                prizeWon = prizeProbabilityVO.getActivityPrizeRefId();


                break;


            }


        }


        Coupon coupon = null;


        //校验优惠卷是否允许用户多领不允许当未中奖处理


        if (prizeWon != null) {


            ActivityRefPrize activityRefPrize = canPrizeMap.get(prizeWon);


            String prizeDrawId = activityRefPrize.getPrizeId();


            PrizeDraw prizeDraw = prizeDrawService.getById(prizeDrawId);


            String couponId = prizeDraw.getCouponId();


            coupon = couponService.getById(couponId);


            if (coupon == null) {


                prizeWon = null;


            } else {


                Integer couponLimitNum = coupon.getCouponLimitNum();


                //获取用户这个优惠卷的中奖情况


                LambdaQueryWrapper<PrizeRecord> eq = Wrappers.<PrizeRecord>lambdaQuery()


                        .eq(PrizeRecord::getUserId, userId)


                        .eq(PrizeRecord::getPrizeActivityId, prizeId)


                        .eq(PrizeRecord::getPrizeId, prizeDrawId);


                int size = prizeRecordService.list(eq).size();


                if ( couponLimitNum>0 && size >= couponLimitNum) {


                    log.info("触发优惠卷领取限制---------->{}",prizeWon);


                    prizeWon = null;


                }


            }




        }


        //未中奖的情况


        if (prizeWon == null) {


@@ -288,6 +330,7 @@


//        if (!lock.equals(nowLock)) {


//            throw new RuntimeException("当前活动太火爆了请稍后再试");


//        }


        String couponId = coupon.getId();


        // 走mq异步处理


        TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {


            @Override


@@ -296,7 +339,10 @@


                rocketMQTemplate.asyncSend(destination, JSON.toJSONString(prizeRecord), RocketmqSendCallbackBuilder.commonCallback());


            }


        });


        return Result.ok().data(activityRefPrize);


        PrizeResultVO prizeResultVO = new PrizeResultVO();


        BeanUtils.copyProperties(activityRefPrize, prizeResultVO);


        prizeResultVO.setCouponId(couponId);


        return Result.ok().data(prizeResultVO);


    }




    public static BigDecimal generateRandom(BigDecimal min, BigDecimal max) {


@@ -384,7 +430,7 @@


        if (useNum >= maxPrize) {


            return Result.ok().data(0);


        } else {


            return Result.ok().data(userPrizeNum>maxPrize?maxPrize-useNum:notUseNum);


            return Result.ok().data(userPrizeNum > maxPrize ? maxPrize - useNum : notUseNum);


        }


    }




@@ -421,16 +467,16 @@


        }


        PrizeDetailVO data = prizeActivityService.prizeInfo(prizeActivityId);


        String activityCover = data.getActivityCover();


        if (StringUtils.isNotBlank(activityCover)&&!activityCover.contains("http")) {


        if (StringUtils.isNotBlank(activityCover) && !activityCover.contains("http")) {


            data.setActivityCover(cosUtil.getPreviewUrl(activityCover));


        }


        data.getPrizeInfoVOS().forEach(info -> {


            String prizeImg = info.getPrizeImg();


            String prizeCover = info.getPrizeCover();


            if (StringUtils.isNotBlank(prizeImg)&&!prizeImg.contains("http")) {


            if (StringUtils.isNotBlank(prizeImg) && !prizeImg.contains("http")) {


                info.setPrizeImg(cosUtil.getPreviewUrl(prizeImg));


            }


            if (StringUtils.isNotBlank(prizeCover)&&!prizeCover.contains("http")) {


            if (StringUtils.isNotBlank(prizeCover) && !prizeCover.contains("http")) {


                info.setPrizeCover(cosUtil.getPreviewUrl(prizeCover));


            }


        });


@@ -441,4 +487,50 @@


    public Result grantRecord(String prizeActivityId) {


        return prizeDrawService.grantRecord(prizeActivityId);


    }




    @Override


    public Result addPrizeNum(AddPrizeNumForm addPrizeNumForm) {


        PrizeActivity activity = prizeActivityService.getById(addPrizeNumForm.getPrizeActivityId());


        if (activity == null) {


            throw new ServiceException("当前活动不存在");


        }


        if (!PrizeActivityStatusEnum.ON.name().equals(activity.getEnableStatus())) {


            throw new ServiceException("当前活动没开启");


        }


        Date date = new Date();


        //活动结束不需要添加


        if (date.after(activity.getEndTime())) {


            throw new ServiceException("当前活动已结束");


        }


        Integer maxPrize = activity.getMaxPrize();


        String userId = addPrizeNumForm.getUserId();


        List<PrizeNumber> prizeNumberList = getPrizeNumberList(activity.getId(), userId);


        if (prizeNumberList.size() >= maxPrize) {


            throw new ServiceException("抽奖次数已达到上限了");


        }


        PrizeUserActionEnum actionEnum = PrizeUserActionEnum.select(addPrizeNumForm.getAddType());


        if (actionEnum == null) {


            throw new ServiceException("当前类型不存在");


        }


        //todo 进行数据校验


        switch (actionEnum) {


            case BUY:


                System.err.println("BUY");


                break;


            case SHARE:


                //直接获得抽奖次数


                System.err.println("SHARE");


                break;


            case SEE_SHOP:


                System.err.println("SEE_SHOP");


                break;


            case SEE_VIDEO:


                System.err.println("SEE_VIDEO");


                break;


            default:




                break;


        }


        return null;


    }


}