package com.yeshi.buwan.videos.pptv;
|
|
import com.yeshi.buwan.domain.user.LoginUserExtra;
|
import com.yeshi.buwan.domain.vip.OrderRecord;
|
import com.yeshi.buwan.domain.vip.OrderType;
|
import com.yeshi.buwan.domain.vip.VIPPrice;
|
import com.yeshi.buwan.domain.vip.VideoBuyRecord;
|
import com.yeshi.buwan.exception.PPTVException;
|
import com.yeshi.buwan.exception.ParamsException;
|
import com.yeshi.buwan.exception.order.OrderException;
|
import com.yeshi.buwan.exception.vip.VIPException;
|
import com.yeshi.buwan.exception.vip.VideoBuyRecordException;
|
import com.yeshi.buwan.videos.pptv.entity.PPTVProgram;
|
import com.yeshi.buwan.videos.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.service.inter.vip.VideoBuyRecordService;
|
import com.yeshi.buwan.util.RedisManager;
|
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;
|
|
@Resource
|
private VideoBuyRecordService videoBuyRecordService;
|
|
@Resource
|
private RedisManager redisManager;
|
|
/**
|
* 购买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会员购买失败");
|
}
|
|
redisManager.cacheCommonString(PPTVUtil.getBuyGoodsCacheKey(record.getUid(), price.getPptvGoodsNo()), "1", 60);
|
|
}
|
|
|
/**
|
* 购买单片
|
*
|
* @param record
|
* @throws PPTVException
|
* @throws VIPException
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
public void buyVideo(OrderRecord record) throws PPTVException, OrderException, VideoBuyRecordException {
|
if (record.getState() != OrderRecord.STATE_PAY) {
|
throw new OrderException(11, "尚未支付成功");
|
}
|
|
if (record.getOrderType() != OrderType.video) {
|
throw new OrderException(41, "不是单片订单");
|
}
|
|
PPTVProgram program = pptvService.selectProgramById(record.getVideoVid());
|
|
|
if (program.getGoodsInfo() == null || StringUtil.isNullOrEmpty(program.getGoodsInfo().getGoodsNo())) {
|
throw new PPTVException(41, "影片商品信息为空");
|
}
|
|
|
LoginUserExtra extra = loginUserService.getExtra(record.getUid());
|
if (extra == null) {
|
throw new OrderException(13, "用户信息获取失败");
|
}
|
|
if (StringUtil.isNullOrEmpty(extra.getPptvUid())) {
|
throw new OrderException(14, "pptvuid获取失败");
|
}
|
|
if (StringUtil.isNullOrEmpty(extra.getPptvOpenId())) {
|
loginUserService.updatePPTVOpenId(record.getUid());
|
}
|
|
boolean success = PPTVApiUtil.buyGoods(extra.getPptvOpenId(), "buwan_" + record.getId(), program.getGoodsInfo().getGoodsNo(), record.getPayTime());
|
if (!success) {
|
throw new VideoBuyRecordException(21, "PPTV单片购买失败");
|
}
|
|
PPTVSeries series = pptvService.selectSeriesBySeriesCode(record.getVideoCid());
|
|
VideoBuyRecord buyRecord = VideoBuyRecord.create(record, series.getInfoID(), series.getSeriesCode(), program.getProgramCode(), program.getGoodsInfo().getGoodsNo());
|
|
try {
|
videoBuyRecordService.addRecord(buyRecord);
|
} catch (ParamsException e) {
|
throw new VideoBuyRecordException(ParamsException.CODE_PARAMS_NOT_ENOUGH, e.getMessage());
|
}
|
|
redisManager.cacheCommonString(PPTVUtil.getBuyGoodsCacheKey(buyRecord.getLoginUid(), buyRecord.getGoodsNo()), "1", 60);
|
}
|
|
|
}
|
