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会员
|
*/
|
@Component
|
public class PPTVVipManager {
|
|
@Resource
|
private VIPPriceService vipPriceService;
|
|
@Resource
|
private LoginUserService loginUserService;
|
|
@Resource
|
private PPTVService pptvService;
|
|
/**
|
* 购买VIP
|
*
|
* @param record
|
* @throws PPTVException
|
* @throws VIPException
|
*/
|
@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会员购买失败");
|
}
|
}
|
|
|
}
|
