package com.ks.lijin.service.manager;
|
|
import com.ks.lijin.mapper.LiJinProviderAccountMapper;
|
import com.ks.lijin.pojo.DO.LiJinProviderTaoKeAccount;
|
import org.springframework.data.redis.core.RedisTemplate;
|
import org.springframework.stereotype.Component;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.yeshi.utils.TimeUtil;
|
|
import javax.annotation.Resource;
|
import java.math.BigDecimal;
|
import java.math.RoundingMode;
|
import java.util.Date;
|
|
@Component
|
public class LiJinProviderTaoKeAccountManager {
|
|
@Resource
|
private LiJinProviderAccountMapper liJinProviderAccountMapper;
|
|
@Resource
|
private RedisTemplate redisTemplate;
|
|
|
/**
|
* 礼金创建成功
|
*
|
* @param accountId
|
* @param auctionId
|
* @param money
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
public void createLijinSuccess(Long accountId, Long auctionId, BigDecimal money, Date createTime) {
|
String day = TimeUtil.getGernalTime(createTime.getTime(), "yyyyMMdd");
|
String goodsKeyPrefix = String.format("lijingoodsnum-%s-%s-", day, accountId);
|
String goodsKey = goodsKeyPrefix + auctionId;
|
String accountMoneyKey = String.format("lijinaccountmoney-%s-%s", day, accountId);
|
//保存账号当日的商品数量消耗
|
redisTemplate.opsForValue().increment(goodsKey, 1);
|
//保存当日账号的资金消耗
|
redisTemplate.opsForValue().increment(accountMoneyKey, money.multiply(new BigDecimal(100)).intValue());
|
|
//获取账号当日的商品数量
|
int goodsNum = redisTemplate.keys(goodsKeyPrefix + "*").size();
|
//获取账号当日的资金消耗
|
Long todayMoney = Long.parseLong(redisTemplate.opsForValue().get(accountMoneyKey) + "");
|
|
//同步到数据库
|
|
LiJinProviderTaoKeAccount account = liJinProviderAccountMapper.selectByPrimaryKeyForUpdate(accountId);
|
if (account != null) {
|
LiJinProviderTaoKeAccount update = new LiJinProviderTaoKeAccount();
|
update.setTodayConsumeMoney(new BigDecimal(todayMoney).divide(new BigDecimal(100), 2, RoundingMode.FLOOR));
|
update.setTodayConsumeNumber(goodsNum);
|
update.setUpdateTime(new Date());
|
liJinProviderAccountMapper.updateByPrimaryKeySelective(update);
|
}
|
}
|
|
|
}
|
