fix: 修复直播延迟消息状态错误

2022-05-26 16:24:39 +08:00 · 2022-05-26 16:24:39 +08:00 · 431ff04644
commit 431ff04644
parent 201fb0a136
1 changed files with 1 additions and 1 deletions
--- a/framework/src/main/java/cn/lili/modules/goods/serviceimpl/StudioServiceImpl.java
+++ b/framework/src/main/java/cn/lili/modules/goods/serviceimpl/StudioServiceImpl.java
@ -121,7 +121,7 @@ public class StudioServiceImpl extends ServiceImpl<StudioMapper, Studio> impleme
                    rocketmqCustomProperties.getPromotionTopic());

            //直播间结束
-            broadcastMessage = new BroadcastMessage(studio.getId(), StudioStatusEnum.START.name());
+            broadcastMessage = new BroadcastMessage(studio.getId(), StudioStatusEnum.END.name());
            this.timeTrigger.edit(
                    TimeExecuteConstant.BROADCAST_EXECUTOR,
                    broadcastMessage,