|  | @@ -129,6 +129,9 @@ public class ImLiveBroadcastRoomServiceImpl extends ServiceImpl<ImLiveBroadcastR
 | 
	
		
			
				|  |  |      private RedissonMessageService redissonMessageService;
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  |      @Autowired
 | 
	
		
			
				|  |  | +    private ImLiveBroadcastRoomService imLiveBroadcastRoomService;
 | 
	
		
			
				|  |  | +
 | 
	
		
			
				|  |  | +    @Autowired
 | 
	
		
			
				|  |  |      private ImFeignService imFeignService;
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  |      //待替换的变量
 | 
	
	
		
			
				|  | @@ -445,7 +448,7 @@ public class ImLiveBroadcastRoomServiceImpl extends ServiceImpl<ImLiveBroadcastR
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  |              Date endTime = DateUtil.addMinutes(now, PRE_LIVE_TIME_MINUTE);
 | 
	
		
			
				|  |  |              if (endTime.getTime() >= dto.getLiveStartTime().getTime()) {
 | 
	
		
			
				|  |  | -                this.createLiveRoom(obj);
 | 
	
		
			
				|  |  | +                imLiveBroadcastRoomService.createLiveRoom(obj);
 | 
	
		
			
				|  |  |              }
 | 
	
		
			
				|  |  |          });
 | 
	
		
			
				|  |  |      }
 | 
	
	
		
			
				|  | @@ -2194,6 +2197,9 @@ public class ImLiveBroadcastRoomServiceImpl extends ServiceImpl<ImLiveBroadcastR
 | 
	
		
			
				|  |  |      @Override
 | 
	
		
			
				|  |  |      @Transactional(rollbackFor = Exception.class)
 | 
	
		
			
				|  |  |      public void createLiveRoom(ImLiveBroadcastRoom room) {
 | 
	
		
			
				|  |  | +        if (StringUtils.isBlank(room.getGroupType())) {
 | 
	
		
			
				|  |  | +            room.setGroupType("NORMAL");
 | 
	
		
			
				|  |  | +        }
 | 
	
		
			
				|  |  |          log.info("createLiveRoom>>>>>>roomUid:{}", room.getRoomUid());
 | 
	
		
			
				|  |  |          try {
 | 
	
		
			
				|  |  |              //生成主讲人信息到缓存
 |