bug修复

admin

2021-04-19 eb7f3343af839a7c71f16e8ada2b25d5e2201c08

 src/main/java/com/yeshi/buwan/pptv/PPTVVipManager.java

@@ -1,6 +1,20 @@
package com.yeshi.buwan.pptv;

import com.yeshi.buwan.domain.user.LoginUserExtra;
import com.yeshi.buwan.domain.vip.OrderType;
import com.yeshi.buwan.domain.vip.OrderRecord;
import com.yeshi.buwan.domain.vip.VIPPrice;
import com.yeshi.buwan.exception.PPTVException;
import com.yeshi.buwan.exception.vip.VIPException;
import com.yeshi.buwan.pptv.entity.PPTVSeries;
import com.yeshi.buwan.service.inter.LoginUserService;
import com.yeshi.buwan.service.inter.juhe.PPTVService;
import com.yeshi.buwan.service.inter.vip.VIPPriceService;
import com.yeshi.buwan.util.StringUtil;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;

/**
 * PPTV会员
@@ -8,12 +22,100 @@
@Component
public class PPTVVipManager {

    @Resource
    private VIPPriceService vipPriceService;

    @Resource
    private LoginUserService loginUserService;

    @Resource
    private PPTVService pptvService;

    /**
     * 购买VIP
     *
     * @param record
     * @throws PPTVException
     * @throws VIPException
     */
    public void buyVIP() {
    @Transactional(rollbackFor = Exception.class)
    public void buyVIP(OrderRecord record) throws PPTVException, VIPException {
        if (record.getState() != OrderRecord.STATE_PAY) {
            throw new VIPException(11, "尚未支付成功");
        }

        if (record.getOrderType() != OrderType.vip) {
            throw new VIPException(41, "不是VIP订单");
        }
        VIPPrice price = vipPriceService.selectByType(record.getType());
        if (price == null) {
            throw new VIPException(12, "无法获取价格套餐");
        }

        LoginUserExtra extra = loginUserService.getExtra(record.getUid());
        if (extra == null) {
            throw new VIPException(13, "用户信息获取失败");
        }

        if (StringUtil.isNullOrEmpty(extra.getPptvUid())) {
            throw new VIPException(14, "pptvuid获取失败");
        }

        if (StringUtil.isNullOrEmpty(extra.getPptvOpenId())) {
            loginUserService.updatePPTVOpenId(record.getUid());
        }

        boolean success = PPTVApiUtil.buyGoods(extra.getPptvOpenId(), "buwan_" + record.getId(), price.getPptvGoodsNo(), record.getPayTime());
        if (!success) {
            throw new VIPException(21, "PPTV会员购买失败");
        }
    }


    /**
     * 购买单片
     *
     * @param record
     * @throws PPTVException
     * @throws VIPException
     */
    @Transactional(rollbackFor = Exception.class)
    public void buyVideo(OrderRecord record) throws PPTVException, VIPException {
        if (record.getState() != OrderRecord.STATE_PAY) {
            throw new VIPException(11, "尚未支付成功");
        }

        if (record.getOrderType() != OrderType.video) {
            throw new VIPException(41, "不是单片订单");
        }

        PPTVSeries pptvSeries = pptvService.getSeriesDetail(record.getVideoInfoId());
        if (pptvSeries == null) {
            throw new VIPException(41, "影片信息获取失败");
        }

        if (pptvSeries.getGoodsInfo() == null || StringUtil.isNullOrEmpty(pptvSeries.getGoodsInfo().getGoodsNo())) {
            throw new VIPException(41, "影片商品信息为空");
        }


        LoginUserExtra extra = loginUserService.getExtra(record.getUid());
        if (extra == null) {
            throw new VIPException(13, "用户信息获取失败");
        }

        if (StringUtil.isNullOrEmpty(extra.getPptvUid())) {
            throw new VIPException(14, "pptvuid获取失败");
        }

        if (StringUtil.isNullOrEmpty(extra.getPptvOpenId())) {
            loginUserService.updatePPTVOpenId(record.getUid());
        }

        boolean success = PPTVApiUtil.buyGoods(extra.getPptvOpenId(), "buwan_" + record.getId(), pptvSeries.getGoodsInfo().getGoodsNo(), record.getPayTime());
        if (!success) {
            throw new VIPException(21, "PPTV会员购买失败");
        }
    }