将CMQ替换为rabbitmq

admin

2024-10-16 62a447d89331aee1feae7724c7616aa1bb2cfe79

 fanli/src/main/java/com/yeshi/fanli/service/impl/tlj/UserTaoLiJinRecordServiceImpl.java

@@ -247,7 +247,7 @@

    @Override
    @Transactional(rollbackFor = Exception.class)
    public UserTaoLiJinRecord createUserTaoLiJin(int origin, Long uid, Long auctionId, BigDecimal perface, int totalNum,
    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 {

@@ -441,7 +441,7 @@
            return list;
        }

        List<Long> listGoodsId = new ArrayList<Long>();
        List<String> listGoodsId = new ArrayList<>();
        for (UserTaoLiJinRecordVO userTaoLiJinRecordVO : list) {
            listGoodsId.add(userTaoLiJinRecordVO.getAuctionId());
        }
@@ -457,13 +457,13 @@

        // 组织相关数据
        for (UserTaoLiJinRecordVO userTaoLiJinRecordVO : list) {
            long auctionId = userTaoLiJinRecordVO.getAuctionId().longValue();
            String auctionId = userTaoLiJinRecordVO.getAuctionId();

            // 商品信息
            for (int i = 0; i < listGoods.size(); i++) {
                CommonGoods commonGoods = listGoods.get(i);
                long goodsId = commonGoods.getGoodsId().longValue();
                if (auctionId == goodsId) {
                String goodsId = commonGoods.getGoodsId();
                if (TaoBaoUtil.isEqual(auctionId , goodsId)) {
                    userTaoLiJinRecordVO.setTitle(commonGoods.getTitle());
                    userTaoLiJinRecordVO.setPictUrl(commonGoods.getPicture());
                    if (CommonGoods.SHOP_TYPE_TB == commonGoods.getShopType()) {