diff --git a/ruoyi-cai/src/main/java/com/ruoyi/cai/ws/handler/message/AgreeMessageHandle.java b/ruoyi-cai/src/main/java/com/ruoyi/cai/ws/handler/message/AgreeMessageHandle.java index ab991057..d8b9cd3f 100644 --- a/ruoyi-cai/src/main/java/com/ruoyi/cai/ws/handler/message/AgreeMessageHandle.java +++ b/ruoyi-cai/src/main/java/com/ruoyi/cai/ws/handler/message/AgreeMessageHandle.java @@ -12,6 +12,7 @@ import com.ruoyi.cai.ws.constant.RoomStatusEnums; import com.ruoyi.cai.ws.dto.WsRMsgGen; import com.ruoyi.cai.ws.handler.IMessageHandler; import com.ruoyi.cai.ws.handler.AbstractMessageHandle; +import com.ruoyi.cai.ws.service.RoomService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; @@ -31,6 +32,8 @@ public class AgreeMessageHandle extends AbstractMessageHandle implements IMessag private UserCallService userCallService; @Autowired private AmqpProducer amqpProducer; + @Autowired + private RoomService roomService; @Override public void processOn(Room room, FdCtxData fdCtxData, JSONObject map) { @@ -51,5 +54,12 @@ public class AgreeMessageHandle extends AbstractMessageHandle implements IMessag amqpProducer.sendRoomSettleDelay(room.getRoomId()+"",60); // 1分钟延时消息,开始扣钱 String message = "提示:禁止任何涉黄、任何微信QQ引导到其它平台行为"; sendToAll(room.getRoomId(), WsRMsgGen.startVideo(room.getRoomId(),0L),WsRMsgGen.sysNotice(message)); + try { + Long callTime = roomService.getCallTime(room); + sendToAll(room.getRoomId(),WsRMsgGen.canCallTime(callTime)); + }catch (Exception e){ + log.error("发送可通话时长失败",e); + } + } }