礼金创建优化

admin

2021-05-29 970e58a0ceb0bfcd52affad3f08c53d30c29ab8d

 service-lijin/src/main/java/com/ks/lijin/service/manager/LiJinProviderTaoKeAccountManager.java

@@ -32,30 +32,49 @@
    @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 goodsKey = String.format("lijingoodsnum-%s-%s", day, accountId);
        String accountMoneyKey = String.format("lijinaccountmoney-%s-%s", day, accountId);
        //保存账号当日的商品数量消耗
        redisTemplate.opsForValue().increment(goodsKey, 1);
        redisTemplate.opsForSet().add(goodsKey, auctionId);
        //保存当日账号的资金消耗
        redisTemplate.opsForValue().increment(accountMoneyKey, money.multiply(new BigDecimal(100)).intValue());

        //获取账号当日的商品数量
        int goodsNum = redisTemplate.keys(goodsKeyPrefix + "*").size();
        long goodsNum = redisTemplate.opsForSet().size(goodsKey);
        //获取账号当日的资金消耗
        Long todayMoney = Long.parseLong(redisTemplate.opsForValue().get(accountMoneyKey) + "");

        //同步到数据库

        LiJinProviderTaoKeAccount account = liJinProviderAccountMapper.selectByPrimaryKeyForUpdate(accountId);
        if (account != null) {
            LiJinProviderTaoKeAccount update = new LiJinProviderTaoKeAccount();
            update.setId(account.getId());
            update.setTodayConsumeMoney(new BigDecimal(todayMoney).divide(new BigDecimal(100), 2, RoundingMode.FLOOR));
            update.setTodayConsumeNumber(goodsNum);
            update.setTodayConsumeNumber((int) goodsNum);
            update.setUpdateTime(new Date());
            update.setErrorCode(LiJinProviderTaoKeAccount.ERROR_CODE_NORMAL);
            liJinProviderAccountMapper.updateByPrimaryKeySelective(update);
        }
    }

    /**
     * 初始化当天的数据
     *
     * @param accountId
     */
    public void initTodayData(Long accountId) {
        createLijinSuccess(accountId, 1L, new BigDecimal(0), new Date());
    }


    //删除redis中的信息
    public void deleteInfoInRedis(Date date) {
        String day = TimeUtil.getGernalTime(date.getTime(), "yyyyMMdd");
        String goodsKey = String.format("lijingoodsnum-%s-*", day);
        String accountMoneyKey = String.format("lijinaccountmoney-%s-%s", day);
        redisTemplate.delete(goodsKey);
        redisTemplate.delete(accountMoneyKey);
    }


}