|
@@ -12,6 +12,7 @@ import com.google.common.collect.Lists;
|
|
|
import com.ym.mec.auth.api.client.SysUserFeignService;
|
|
|
import com.ym.mec.auth.api.entity.SysUser;
|
|
|
import com.ym.mec.biz.dal.dao.ImLiveBroadcastRoomDao;
|
|
|
+import com.ym.mec.biz.dal.dao.LiveGoodsMapperDao;
|
|
|
import com.ym.mec.biz.dal.dao.SysConfigDao;
|
|
|
import com.ym.mec.biz.dal.dto.ImLiveBroadcastRoomDto;
|
|
|
import com.ym.mec.biz.dal.entity.ImLiveBroadcastRoom;
|
|
@@ -80,7 +81,7 @@ public class ImLiveBroadcastRoomServiceImpl extends ServiceImpl<ImLiveBroadcastR
|
|
|
@Autowired
|
|
|
private ImLiveBroadcastRoomDataService liveBroadcastRoomDataService;
|
|
|
@Autowired
|
|
|
- private LiveGoodsMapperService liveGoodsMapperService;
|
|
|
+ private LiveGoodsMapperDao liveGoodsMapperDao;
|
|
|
|
|
|
//待替换的变量
|
|
|
public static final String USER_ID = "${userId}";
|
|
@@ -440,7 +441,7 @@ public class ImLiveBroadcastRoomServiceImpl extends ServiceImpl<ImLiveBroadcastR
|
|
|
this.updateById(room);
|
|
|
|
|
|
//下架商品
|
|
|
- liveGoodsMapperService.downGoods(room.getRoomUid());
|
|
|
+ liveGoodsMapperDao.updateStatus(room.getRoomUid(),null,false);
|
|
|
|
|
|
//向聊天室发自定义消息踢出所有人
|
|
|
try {
|