init

2024-03-02 23:32:29 +08:00
parent d5dff605bb
commit 8978da0189
2 changed files with 2 additions and 2 deletions
--- a/ruoyi-cai/src/main/java/com/ruoyi/cai/manager/ConsumerManager.java
+++ b/ruoyi-cai/src/main/java/com/ruoyi/cai/manager/ConsumerManager.java
@@ -123,7 +123,7 @@ public class ConsumerManager {
        }catch (Exception e){
            log.error("RabbitMq 发送失败, 视频分销流程流转失败！",e);
        }
-        rankManager.sendLoveRankMq(consumeLog.getSourceUserId(),consumeLog.getAnchorAmount(),consumeLog.getTraceId());
+        rankManager.sendLoveRankMq(consumeLog.getTargetUserId(),consumeLog.getAnchorAmount(),consumeLog.getTraceId());
        return resp;
    }
    @Autowired