記錄一次，事務遇到消息發送，疏忽給本身挖坑

場景：一個異步重算功能（任務新建後發送消息到RocketMq），每次重算單條記錄的時候，能夠計算正確，可是當多條記錄批量重算時，結果老是莫名其妙的不對。排查了好久，終於找到緣由

緣由：在新建重算任務方法上添加了事務註解，而發送消息也在該方法中，致使事務未提交，消息已經發出去了。

源代碼：

    @Transactional
    public void updateGiftCostByTradeList(ShopShard shopShard, List<Trade> tradeList) {
        Preconditions.checkArgument(null != shopShard && !CollectionUtils.isEmpty(tradeList));

        for (Trade trade : tradeList) {
            if (TradeSpecialTypeEnum.getSpecialTypes().contains(trade.getTradeSpecialType())) {
                continue;
            }
            long giftCost = getGiftCostFromZhanggui(shopShard.getShopId(), trade);
            giftCost = giftCost > 0 ? giftCost : getGiftCostFromCaiwu(shopShard.getShopId(), trade);

            if ((trade.getGiftFee() == null ? 0 : trade.getGiftFee()) == giftCost) {
                continue;
            }
            tradeService.updateTradeGiftFee(shopShard.getShopId(), trade.getId(), giftCost);
            SendMsgToMqUtil.sendTradeMsgToTradeFeeTopic(rocketMqProducer, shopShard, trade);
        }
    }

更改後：

 @Transactional
    public void updateGiftCostByTradeList(ShopShard shopShard, List<Trade> tradeList) {
        Preconditions.checkArgument(null != shopShard && !CollectionUtils.isEmpty(tradeList));

        for (Trade trade : tradeList) {
            if (TradeSpecialTypeEnum.getSpecialTypes().contains(trade.getTradeSpecialType())) {
                continue;
            }
            long giftCost = getGiftCostFromZhanggui(shopShard.getShopId(), trade);
            giftCost = giftCost > 0 ? giftCost : getGiftCostFromCaiwu(shopShard.getShopId(), trade);

            if ((trade.getGiftFee() == null ? 0 : trade.getGiftFee()) == giftCost) {
                continue;
            }
            tradeService.updateTradeGiftFee(shopShard.getShopId(), trade.getId(), giftCost);
        }
    }


private void doProcessCostRule(ShopShard shopShard, CostRule costRule) {

     commonCostRuleService.updateGiftCostByTradeList(shopShard, pageInfo.getList());
     pageInfo.getList().forEach(trade -> { if (!recalStatPoolCommonServcie.sendMqToRecalStatPoolByTrade(trade, TradeStatRecalSourceEnum.GIFT_COST)) { log.error("process costRule trade send recalstatpool false shopId={}|trade={}", shopShard.getShopId(), JSON.toJSONString(trade)); } });

}