package com.yeshi.fanli.service.impl.tlj;
|
|
import java.math.BigDecimal;
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
import javax.annotation.Resource;
|
|
import com.yeshi.fanli.entity.SystemEnum;
|
import com.yeshi.fanli.entity.SystemPIDInfo;
|
import com.yeshi.fanli.service.inter.user.UserInfoService;
|
import com.yeshi.fanli.service.manger.PIDManager;
|
import org.springframework.core.task.TaskExecutor;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.yeshi.utils.BigDecimalUtil;
|
import org.yeshi.utils.DateUtil;
|
|
import com.yeshi.fanli.dao.mybatis.tlj.UserTaoLiJinRecordMapper;
|
import com.yeshi.fanli.dto.msg.MsgOtherTaoLiJinContentDTO;
|
import com.yeshi.fanli.dto.taobao.TaoLiJinDTO;
|
import com.yeshi.fanli.entity.bus.tlj.UserTaoLiJinDetail;
|
import com.yeshi.fanli.entity.bus.tlj.UserTaoLiJinDetail.TaoLiJinDetailTypeEnum;
|
import com.yeshi.fanli.entity.bus.tlj.UserTaoLiJinGiveRecord;
|
import com.yeshi.fanli.entity.bus.tlj.UserTaoLiJinOrigin;
|
import com.yeshi.fanli.entity.bus.tlj.UserTaoLiJinRecord;
|
import com.yeshi.fanli.entity.bus.user.TokenRecord;
|
import com.yeshi.fanli.entity.bus.user.TokenRecord.TokenTypeEnum;
|
import com.yeshi.fanli.entity.bus.user.vip.UserLevelEnum;
|
import com.yeshi.fanli.entity.bus.user.UserMoneyExtra;
|
import com.yeshi.fanli.entity.goods.CommonGoods;
|
import com.yeshi.fanli.entity.system.ConfigKeyEnum;
|
import com.yeshi.goods.facade.entity.taobao.TaoBaoGoodsBrief;
|
import com.yeshi.common.entity.taobao.TaoKeAppInfo;
|
import com.yeshi.fanli.exception.taobao.TaoKeApiException;
|
import com.yeshi.fanli.exception.tlj.TaoLiJinCreateException;
|
import com.yeshi.fanli.exception.tlj.UserTaoLiJinRecordException;
|
import com.yeshi.fanli.log.LogHelper;
|
import com.yeshi.fanli.service.inter.config.ConfigService;
|
import com.yeshi.fanli.service.inter.goods.CommonGoodsService;
|
import com.yeshi.fanli.service.inter.money.UserMoneyExtraService;
|
import com.yeshi.fanli.service.inter.msg.UserOtherMsgNotificationService;
|
import com.yeshi.fanli.service.inter.order.config.HongBaoManageService;
|
import com.yeshi.fanli.service.inter.taobao.ShareHotGoodsService;
|
import com.yeshi.fanli.service.inter.taobao.TaoBaoBuyRelationMapService;
|
import com.yeshi.fanli.service.inter.tlj.ConfigTaoLiJinService;
|
import com.yeshi.fanli.service.inter.tlj.UserTaoLiJinDetailService;
|
import com.yeshi.fanli.service.inter.tlj.UserTaoLiJinGiveRecordService;
|
import com.yeshi.fanli.service.inter.tlj.UserTaoLiJinOriginService;
|
import com.yeshi.fanli.service.inter.tlj.UserTaoLiJinRecordService;
|
import com.yeshi.fanli.service.inter.tlj.UserTaoLiJinReportService;
|
import com.yeshi.fanli.service.inter.user.TokenRecordService;
|
import com.yeshi.fanli.service.inter.user.UserInfoExtraService;
|
import com.yeshi.fanli.service.inter.user.tb.UserExtraTaoBaoInfoService;
|
import com.yeshi.fanli.util.Constant;
|
import org.yeshi.utils.MoneyBigDecimalUtil;
|
import com.yeshi.fanli.util.RedisManager;
|
import com.yeshi.fanli.util.StringUtil;
|
import com.yeshi.fanli.util.TaoBaoConstant;
|
import com.yeshi.fanli.util.TokenUtil;
|
import com.yeshi.fanli.util.factory.CommonGoodsFactory;
|
import com.yeshi.fanli.util.taobao.TaoBaoUtil;
|
import com.yeshi.fanli.util.taobao.TaoKeApiUtil;
|
import com.yeshi.fanli.util.taobao.TaoLiJinUtil;
|
import com.yeshi.common.vo.ClientTextStyleVO;
|
import com.yeshi.fanli.vo.user.UserTaoLiJinRecordVO;
|
|
@Service
|
public class UserTaoLiJinRecordServiceImpl implements UserTaoLiJinRecordService {
|
|
@Resource(name = "taskExecutor")
|
private TaskExecutor executor;
|
|
@Resource
|
private RedisManager redisManager;
|
|
@Resource
|
private ConfigService configService;
|
|
@Resource
|
private UserTaoLiJinRecordMapper userTaoLiJinRecordMapper;
|
|
@Resource
|
private CommonGoodsService commonGoodsService;
|
|
@Resource
|
private HongBaoManageService hongBaoManageService;
|
|
@Resource
|
private UserMoneyExtraService userMoneyExtraService;
|
|
@Resource
|
private UserTaoLiJinReportService userTaoLiJinReportService;
|
|
@Resource
|
private UserTaoLiJinDetailService userTaoLiJinDetailService;
|
|
@Resource
|
private UserTaoLiJinOriginService userTaoLiJinOriginService;
|
|
@Resource
|
private ConfigTaoLiJinService configTaoLiJinService;
|
|
@Resource
|
private UserOtherMsgNotificationService userOtherMsgNotificationService;
|
|
@Resource
|
private UserInfoExtraService userInfoExtraService;
|
|
@Resource
|
private UserExtraTaoBaoInfoService userExtraTaoBaoInfoService;
|
|
@Resource
|
private TaoBaoBuyRelationMapService taoBaoBuyRelationMapService;
|
|
@Resource
|
private ShareHotGoodsService shareHotGoodsService;
|
|
@Resource
|
private TokenRecordService tokenRecordService;
|
|
@Resource
|
private UserTaoLiJinGiveRecordService userTaoLiJinGiveRecordService;
|
|
@Resource
|
private UserInfoService userInfoService;
|
|
@Override
|
public UserTaoLiJinRecord selectByPrimaryKey(Long id) {
|
return userTaoLiJinRecordMapper.selectByPrimaryKey(id);
|
}
|
|
@Resource
|
private PIDManager pidManager;
|
|
@Transactional(rollbackFor = Exception.class)
|
@Override
|
public UserTaoLiJinRecord createSelfBuyTaoLiJin(Long uid, BigDecimal couplePrice, TaoBaoGoodsBrief goods)
|
throws UserTaoLiJinRecordException {
|
Date date = new Date();
|
SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");
|
SimpleDateFormat formatStr = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
String date_str = format.format(date);
|
String sendEndTime_str = date_str + " 22:00:00";
|
String useEndTime_str = date_str + " 23:59:59";
|
/* 创建淘礼金 */
|
String name = "自购淘礼金红包";
|
// 发放开始时间
|
Date sendStartTime = date;
|
// 发放截止时间 - 分享当日22:00
|
Date sendEndTime = null;
|
// 使用结束日期 - 分享当日 23：59
|
Date useEndTime = null;
|
try {
|
sendEndTime = formatStr.parse(sendEndTime_str);
|
useEndTime = formatStr.parse(useEndTime_str);
|
} catch (ParseException e2) {
|
e2.printStackTrace();
|
}
|
|
if (!TaoBaoUtil.isSpecialGoods(goods.getMaterialLibType())) {// 非返利库商品
|
String relationId = null;
|
try {
|
relationId = taoBaoBuyRelationMapService.getRelationId(uid);
|
} catch (Exception e) {
|
LogHelper.errorDetailInfo(e, "uid:" + uid, null);
|
}
|
|
if (StringUtil.isNullOrEmpty(relationId)) {
|
throw new UserTaoLiJinRecordException(101, "渠道未备案");
|
}
|
UserTaoLiJinRecord record = createUserTaoLiJin(1, uid, goods.getAuctionId(), couplePrice, 1, name,
|
sendStartTime, sendEndTime, null, useEndTime, pidManager.getPidCache(SystemEnum.blks, Constant.SOURCE_TYPE_TAOBAO, SystemPIDInfo.PidType.fanliChannel));
|
record.setSendUrl(record.getSendUrl() + "&relationId=" + relationId);
|
UserTaoLiJinRecord updateRecoed = new UserTaoLiJinRecord();
|
updateRecoed.setId(record.getId());
|
updateRecoed.setSendUrl(record.getSendUrl());
|
userTaoLiJinRecordMapper.updateByPrimaryKeySelective(record);
|
return record;
|
} else {// 返利库商品
|
return createUserTaoLiJin(1, uid, goods.getAuctionId(), couplePrice, 1, name, sendStartTime, sendEndTime, null,
|
useEndTime, pidManager.getPidCache(SystemEnum.blks, Constant.SOURCE_TYPE_TAOBAO, SystemPIDInfo.PidType.fanli));
|
}
|
|
}
|
|
@Transactional(rollbackFor = Exception.class)
|
@Override
|
public UserTaoLiJinRecord createShareTaoLiJin(Long uid, int totalNum, TaoBaoGoodsBrief goods)
|
throws UserTaoLiJinRecordException {
|
String relationId = userExtraTaoBaoInfoService.getRelationIdByUid(uid);
|
if (StringUtil.isNullOrEmpty(relationId))
|
throw new UserTaoLiJinRecordException(101, "渠道未授权");
|
|
Date date = new Date();
|
SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");
|
SimpleDateFormat formatStr = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
String date_str = format.format(date);
|
String sendEndTime_str = date_str + " 22:00:00";
|
String useEndTime_str = date_str + " 23:59:59";
|
/* 创建淘礼金 */
|
String name = "分享淘礼金红包";
|
// 发放开始时间
|
Date sendStartTime = date;
|
// 发放截止时间 - 分享当日22:00
|
Date sendEndTime = null;
|
// 使用结束日期 - 分享当日 23：59
|
Date useEndTime = null;
|
try {
|
sendEndTime = formatStr.parse(sendEndTime_str);
|
useEndTime = formatStr.parse(useEndTime_str);
|
} catch (ParseException e2) {
|
e2.printStackTrace();
|
}
|
|
boolean isNewUser = userInfoExtraService.isNewUser(uid);
|
if (isNewUser) {
|
// 判定为老用户： 新人只要使用了新人红包，也就是那1块钱，那么，他看到的分享爆款中的商品-就只能分享。
|
long countRecord = userTaoLiJinRecordMapper.countRecordByUid(uid);
|
if (countRecord > 0) {
|
isNewUser = false;
|
}
|
}
|
|
BigDecimal perface = null;
|
if (isNewUser) {
|
perface = new BigDecimal(1);
|
} else {
|
// 计算推广红包
|
String warningRate = configTaoLiJinService.getValueByKey("warning_value", new Date());
|
perface = TaoLiJinUtil.getSpreadMoney(warningRate, goods);
|
}
|
|
UserTaoLiJinRecord record = createUserTaoLiJin(2, uid, goods.getAuctionId(), perface, totalNum, name,
|
sendStartTime, sendEndTime, null, useEndTime, TaoBaoConstant.TAOBAO_TLJ_RELATION_PID_DEFAULT);
|
String sendUrl = record.getSendUrl() + "&relationId=" + relationId;
|
record.setSendUrl(sendUrl);
|
UserTaoLiJinRecord updateRecoed = new UserTaoLiJinRecord();
|
updateRecoed.setId(record.getId());
|
updateRecoed.setSendUrl(sendUrl);
|
userTaoLiJinRecordMapper.updateByPrimaryKeySelective(record);
|
return record;
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public UserTaoLiJinRecord createUserTaoLiJin(int origin, Long uid, String auctionId, BigDecimal perface, int totalNum,
|
String name, Date sendStartTime, Date sendEndTime, Date useStartTime, Date useEndTime, String pid)
|
throws UserTaoLiJinRecordException {
|
|
// 用户剩余可以淘礼金验证
|
UserMoneyExtra userMoneyExtra = userMoneyExtraService.selectByPrimaryKey(uid);
|
if (userMoneyExtra == null || userMoneyExtra.getTlj() == null) {
|
throw new UserTaoLiJinRecordException(101, "红包余额不足");
|
}
|
|
// 过期 -取消收回
|
// userTaoLiJinOriginService.overdueHongBao(uid);
|
|
// 总推广红包
|
BigDecimal totalMoney = MoneyBigDecimalUtil.mul(perface, new BigDecimal(totalNum));
|
|
// 自购时的红包余额
|
if (origin == 1) {
|
BigDecimal tljSelf = userMoneyExtra.getTljSelf();
|
if (tljSelf == null || tljSelf.compareTo(totalMoney) < 0) {
|
throw new UserTaoLiJinRecordException(101, "自购红包余额不足");
|
}
|
}
|
|
// 分享时的红包余额
|
BigDecimal tlj = userMoneyExtra.getTlj();
|
if (tlj == null || tlj.compareTo(totalMoney) < 0) {
|
throw new UserTaoLiJinRecordException(101, "分享红包余额不足");
|
}
|
|
// 创建淘礼金红包
|
TaoLiJinDTO taoLiJinDTO = null;
|
try {
|
taoLiJinDTO = TaoKeApiUtil.createTaoLiJin(auctionId, name, perface, totalNum, sendStartTime, sendEndTime,
|
useStartTime, useEndTime,
|
new TaoKeAppInfo(TaoBaoConstant.TAOBAO_AUTH_APPKEY, TaoBaoConstant.TAOBAO_AUTH_APPSECRET, pid));
|
} catch (TaoLiJinCreateException e) {
|
LogHelper.errorDetailInfo(e);
|
executor.execute(new Runnable() {
|
@Override
|
public void run() {
|
if (e.getCode() == TaoLiJinCreateException.CODE_TLJ_FORBIDDEN) {
|
// 该商品不支持创建淘礼金红包
|
shareHotGoodsService.deleteByGoodsId(auctionId);
|
} else if (e.getCode() == TaoLiJinCreateException.CODE_TLJ_NO_MONEY) {
|
// 官方玩法钱包余额不足 TODO
|
}
|
}
|
});
|
} catch (TaoKeApiException e1) {
|
}
|
|
if (taoLiJinDTO == null) {
|
throw new UserTaoLiJinRecordException(101, "淘宝API推广红包创建失败");
|
}
|
|
// 保存记录
|
UserTaoLiJinRecord record = new UserTaoLiJinRecord();
|
record.setUid(uid);
|
record.setGoodsId(auctionId);
|
record.setName(name);
|
record.setPerFace(perface);
|
record.setTotalNum(totalNum);
|
record.setSendStartTime(sendStartTime);
|
record.setSendEndTime(sendEndTime);
|
record.setUseStartTime(useStartTime);
|
record.setUseEndTime(useEndTime);
|
record.setRightsId(taoLiJinDTO.getRightsId());
|
record.setSendUrl(taoLiJinDTO.getSendUrl());
|
record.setCreateTime(new Date());
|
if (origin == 1) { // 自购
|
record.setUseType(1);
|
} else { // 分享
|
record.setUseType(2);
|
}
|
|
userTaoLiJinRecordMapper.insertSelective(record);
|
|
BigDecimal surplusTlj = MoneyBigDecimalUtil.sub(tlj, totalMoney);
|
|
UserMoneyExtra updateExtra = new UserMoneyExtra();
|
updateExtra.setUid(uid);
|
if (origin == 1) { // 剩余淘礼金-- 自购
|
updateExtra.setTljSelf(MoneyBigDecimalUtil.sub(userMoneyExtra.getTljSelf(), totalMoney));
|
}
|
updateExtra.setTlj(surplusTlj);
|
updateExtra.setUpdateTime(new Date());
|
userMoneyExtraService.updateByPrimaryKeySelective(updateExtra);
|
|
record.setSurplusMoney(surplusTlj);
|
|
// 异步
|
String rightsId = taoLiJinDTO.getRightsId();
|
executor.execute(new Runnable() {
|
@Override
|
public void run() {
|
try {
|
// 插入明细
|
UserTaoLiJinDetail detail = new UserTaoLiJinDetail();
|
detail.setUid(uid);
|
detail.setMoney(new BigDecimal("-" + totalMoney));
|
detail.setTitle(TaoLiJinDetailTypeEnum.reduce.getDesc());
|
detail.setType(TaoLiJinDetailTypeEnum.reduce);
|
detail.setCreateTime(new Date());
|
userTaoLiJinDetailService.insertSelective(detail);
|
} catch (Exception e) {
|
LogHelper.errorDetailInfo(e);
|
}
|
|
// 成功使用红包
|
try {
|
BigDecimal total = totalMoney;
|
BigDecimal lastMoney = null;
|
BigDecimal zero = new BigDecimal(0);
|
|
// 修改余额
|
List<UserTaoLiJinOrigin> list = userTaoLiJinOriginService.getSurplusLiJin(uid);
|
if (list != null && list.size() > 0) {
|
for (UserTaoLiJinOrigin taoLiJinOrigin : list) {
|
if (total.compareTo(zero) < 1) {
|
break;
|
}
|
BigDecimal moneySurplus = taoLiJinOrigin.getMoneySurplus();
|
lastMoney = total;
|
total = MoneyBigDecimalUtil.sub(total, moneySurplus);
|
if (total.compareTo(zero) >= 0) {
|
moneySurplus = zero;
|
} else {
|
moneySurplus = MoneyBigDecimalUtil.sub(moneySurplus, lastMoney);
|
}
|
|
UserTaoLiJinOrigin usertlj = new UserTaoLiJinOrigin();
|
usertlj.setId(taoLiJinOrigin.getId());
|
usertlj.setMoneySurplus(moneySurplus);
|
usertlj.setUpdateTime(new Date());
|
userTaoLiJinOriginService.updateByPrimaryKeySelective(usertlj);
|
}
|
}
|
} catch (Exception e) {
|
LogHelper.errorDetailInfo(e);
|
}
|
|
// 创建报告
|
try {
|
userTaoLiJinReportService.insertDefault(rightsId);
|
} catch (Exception e) {
|
LogHelper.errorDetailInfo(e);
|
}
|
|
if (origin == 1) {
|
return; // 自购不推送消息
|
}
|
|
// 使用成功消息
|
try {
|
String beizhu = "未被领取或领取后未使用部分退回";
|
SimpleDateFormat sd = new SimpleDateFormat("yyyy.MM.dd HH:mm");
|
String time = sd.format(new Date());
|
MsgOtherTaoLiJinContentDTO content = new MsgOtherTaoLiJinContentDTO();
|
content.setState("红包扣除");
|
content.setSource(time + " 创建的分享记录");
|
content.setMoney(totalMoney);
|
|
//userOtherMsgNotificationService.taoLiJinMsg(uid, beizhu, content);
|
} catch (Exception e) {
|
LogHelper.errorDetailInfo(e);
|
}
|
|
// 检测商品是否存在
|
try {
|
CommonGoods commonGoods = commonGoodsService.getCommonGoodsByGoodsIdAndGoodsType(auctionId,
|
CommonGoods.GOODS_TYPE_TB);
|
if (commonGoods == null) {
|
TaoBaoGoodsBrief taoBaoGoodsBrief = redisManager.getTaoBaoGoodsBrief(auctionId);
|
if (taoBaoGoodsBrief != null) {
|
commonGoodsService.addCommonGoods(CommonGoodsFactory.create(taoBaoGoodsBrief));
|
}
|
}
|
} catch (Exception e) {
|
LogHelper.errorDetailInfo(e);
|
}
|
}
|
});
|
|
return record;
|
}
|
|
@Override
|
public List<UserTaoLiJinRecordVO> getRecordByUid(long start, int count, Long uid) {
|
List<UserTaoLiJinRecordVO> list = userTaoLiJinRecordMapper.getRecordByUid(start, count, uid);
|
if (list == null || list.size() == 0) {
|
return list;
|
}
|
|
List<String> listGoodsId = new ArrayList<>();
|
for (UserTaoLiJinRecordVO userTaoLiJinRecordVO : list) {
|
listGoodsId.add(userTaoLiJinRecordVO.getAuctionId());
|
}
|
|
if (listGoodsId.size() == 0) {
|
return null;
|
}
|
|
List<CommonGoods> listGoods = commonGoodsService.getByListGoodsId(listGoodsId, Constant.SOURCE_TYPE_TAOBAO);
|
if (listGoods == null || listGoods.size() == 0) {
|
return null;
|
}
|
|
// 组织相关数据
|
for (UserTaoLiJinRecordVO userTaoLiJinRecordVO : list) {
|
String auctionId = userTaoLiJinRecordVO.getAuctionId();
|
|
// 商品信息
|
for (int i = 0; i < listGoods.size(); i++) {
|
CommonGoods commonGoods = listGoods.get(i);
|
String goodsId = commonGoods.getGoodsId();
|
if (TaoBaoUtil.isEqual(auctionId , goodsId)) {
|
userTaoLiJinRecordVO.setTitle(commonGoods.getTitle());
|
userTaoLiJinRecordVO.setPictUrl(commonGoods.getPicture());
|
if (CommonGoods.SHOP_TYPE_TB == commonGoods.getShopType()) {
|
userTaoLiJinRecordVO.setUserType(0);
|
} else {
|
userTaoLiJinRecordVO.setUserType(1);
|
}
|
break;
|
}
|
}
|
|
// 计算剩余未领取数量
|
int winNum = userTaoLiJinRecordVO.getWinNum();
|
int totalNum = userTaoLiJinRecordVO.getTotalNum();
|
userTaoLiJinRecordVO.setSurplusNum(totalNum - winNum);
|
SystemEnum system = userInfoService.getUserSystem(uid);
|
|
// 计算分享奖金
|
BigDecimal shareMoney = new BigDecimal(0);
|
BigDecimal commission = userTaoLiJinRecordVO.getCommission();
|
if (commission != null && commission.compareTo(shareMoney) > 0) {
|
BigDecimal shareRate = hongBaoManageService.getShareRate(UserLevelEnum.daRen, system);
|
shareMoney = MoneyBigDecimalUtil.mul(commission,
|
MoneyBigDecimalUtil.div(shareRate, new BigDecimal(100)));
|
shareMoney = BigDecimalUtil.getWithNoZera(shareMoney);
|
}
|
|
ClientTextStyleVO desc = new ClientTextStyleVO();
|
desc.setColor("#FFFFFF");
|
desc.setContent("预估分享奖金：￥" + shareMoney);
|
desc.setBottomColor("#E8AE48");
|
userTaoLiJinRecordVO.setDesc(desc);
|
}
|
return list;
|
}
|
|
@Override
|
public long countRecordByUid(Long uid) {
|
return userTaoLiJinRecordMapper.countRecordByUid(uid);
|
}
|
|
@Override
|
public long countShareRecordByUid(Long uid) {
|
return userTaoLiJinRecordMapper.countShareRecordByUid(uid);
|
}
|
|
@Override
|
public long countTodayNum(Long uid) {
|
return userTaoLiJinRecordMapper.countTodayNum(uid);
|
}
|
|
@Override
|
public BigDecimal getShareHongBaoByUidAndGoodsId(Long uid, Long goodsId) {
|
return userTaoLiJinRecordMapper.getShareHongBaoByUidAndGoodsId(uid, goodsId);
|
}
|
|
@Override
|
public UserTaoLiJinRecord getByRightsId(String rightsId) {
|
return userTaoLiJinRecordMapper.getByRightsId(rightsId);
|
}
|
|
@Override
|
public String giveTaolijin(Long uid, BigDecimal amount) throws UserTaoLiJinRecordException {
|
if (uid == null || amount == null)
|
throw new UserTaoLiJinRecordException(1, "参数不正确");
|
|
String giveMin = configTaoLiJinService.getValueByKey("give_min_amount");
|
if (amount.compareTo(new BigDecimal(giveMin)) < 0)
|
throw new UserTaoLiJinRecordException(1, "赠送推广红包金额至少" + giveMin + "元");
|
|
// 用户剩余可以淘礼金验证
|
UserMoneyExtra userMoneyExtra = userMoneyExtraService.selectByPrimaryKey(uid);
|
if (userMoneyExtra == null || userMoneyExtra.getTlj() == null)
|
throw new UserTaoLiJinRecordException(1, "红包余额不足");
|
|
BigDecimal tlj = userMoneyExtra.getTlj();
|
if (amount.compareTo(tlj) > 0)
|
throw new UserTaoLiJinRecordException(1, "红包余额不足");
|
|
Date nowDate = new Date();
|
// 赠送记录
|
UserTaoLiJinGiveRecord giveRecord = new UserTaoLiJinGiveRecord();
|
giveRecord.setAmount(amount);
|
giveRecord.setGiveUid(uid);
|
giveRecord.setState(UserTaoLiJinGiveRecord.STATE_INIT);
|
giveRecord.setGiveTime(nowDate);
|
giveRecord.setEndTime(DateUtil.plusDayDate(Constant.GIVE_DAYS, new Date()));
|
userTaoLiJinGiveRecordService.insertSelective(giveRecord);
|
|
// 口令记录
|
TokenRecord tokenRecord = new TokenRecord();
|
tokenRecord.setUid(uid);
|
tokenRecord.setIdentify(giveRecord.getId() + "");
|
tokenRecord.setType(TokenTypeEnum.taoLiJin);
|
tokenRecord.setStartTime(nowDate);
|
tokenRecord.setEndTime(DateUtil.plusDayDate(Constant.TOKEN_DAYS, new Date()));
|
tokenRecord.setState(0);
|
tokenRecordService.insertSelective(tokenRecord);
|
|
// 创建口令
|
String token = TokenUtil.createToken(tokenRecord.getId());
|
tokenRecord.setToken(token);
|
tokenRecordService.updateByPrimaryKeySelective(tokenRecord);
|
|
// 更新余额
|
UserMoneyExtra updateExtra = new UserMoneyExtra();
|
updateExtra.setUid(uid);
|
updateExtra.setTlj(MoneyBigDecimalUtil.sub(tlj, amount));
|
updateExtra.setUpdateTime(new Date());
|
userMoneyExtraService.updateByPrimaryKeySelective(updateExtra);
|
|
SystemEnum system = userInfoService.getUserSystem(uid);
|
|
String tips = configTaoLiJinService.getValueByKey("give_taolijin_tips");
|
String projectChineseName = Constant.systemCommonConfig.getProjectChineseName();
|
while (tips.contains("{APP名称}")) {
|
tips = tips.replace("{APP名称}", projectChineseName);
|
}
|
tips = tips.replace("{口令}", token).replace("{下载链接}", configService.getValue(ConfigKeyEnum.appDownLink.getKey(), system)).replace("{面额}",
|
amount.setScale(0).toString());
|
|
executor.execute(new Runnable() {
|
@Override
|
public void run() {
|
try {
|
// 插入明细
|
UserTaoLiJinDetail detail = new UserTaoLiJinDetail();
|
detail.setUid(uid);
|
detail.setMoney(new BigDecimal("-" + amount));
|
detail.setTitle(TaoLiJinDetailTypeEnum.give.getDesc());
|
detail.setType(TaoLiJinDetailTypeEnum.give);
|
detail.setCreateTime(new Date());
|
userTaoLiJinDetailService.insertSelective(detail);
|
} catch (Exception e) {
|
LogHelper.errorDetailInfo(e);
|
}
|
|
// 成功使用红包
|
try {
|
BigDecimal total = amount;
|
BigDecimal lastMoney = null;
|
BigDecimal zero = new BigDecimal(0);
|
// 修改余额
|
List<UserTaoLiJinOrigin> list = userTaoLiJinOriginService.getSurplusLiJin(uid);
|
if (list != null && list.size() > 0) {
|
for (UserTaoLiJinOrigin taoLiJinOrigin : list) {
|
if (total.compareTo(zero) < 1) {
|
break;
|
}
|
BigDecimal moneySurplus = taoLiJinOrigin.getMoneySurplus();
|
lastMoney = total;
|
total = MoneyBigDecimalUtil.sub(total, moneySurplus);
|
if (total.compareTo(zero) >= 0) {
|
moneySurplus = zero;
|
} else {
|
moneySurplus = MoneyBigDecimalUtil.sub(moneySurplus, lastMoney);
|
}
|
|
UserTaoLiJinOrigin usertlj = new UserTaoLiJinOrigin();
|
usertlj.setId(taoLiJinOrigin.getId());
|
usertlj.setMoneySurplus(moneySurplus);
|
usertlj.setUpdateTime(new Date());
|
userTaoLiJinOriginService.updateByPrimaryKeySelective(usertlj);
|
}
|
}
|
} catch (Exception e) {
|
LogHelper.errorDetailInfo(e);
|
}
|
}
|
});
|
|
return tips;
|
}
|
|
}
|
