From 2cf0a5149be07bcaed16b71ebec0410816addc8e Mon Sep 17 00:00:00 2001 From: 2210088963 <2210088963@qq.com> Date: Tue, 7 Jan 2025 18:29:32 +0800 Subject: [PATCH] =?UTF-8?q?1.=E6=B3=A8=E9=87=8A=E6=9B=B4=E6=96=B0=E7=8E=B0?= =?UTF-8?q?=E5=9C=BA=E4=B8=ADupdate=E6=96=B9=E6=B3=95=E7=9A=84updateSceneR?= =?UTF-8?q?eporterStream=E6=96=B9=E6=B3=95=202.=E5=88=86=E9=A1=B5=E6=95=B0?= =?UTF-8?q?=E6=8D=AE=E4=B8=ADpage=E6=96=B9=E6=B3=95=E7=9A=84=E4=BC=A0?= =?UTF-8?q?=E5=8F=82=EF=BC=8C=E7=8E=B0=E5=9C=BA=E7=B1=BB=E5=9E=8BsceneType?= =?UTF-8?q?=E9=BB=98=E8=AE=A4=E8=AE=BE=E7=BD=AE=E4=B8=BA5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../live/controller/LiveSceneController.java | 11 +-- .../service/impl/LiveSceneServiceImpl.java | 89 +++++++++++-------- .../live/service/impl/LuceneServiceImpl.java | 2 +- .../modules/live/vo/SceneEntityVo.java | 5 ++ src/main/resources/application.yml | 1 + 5 files changed, 64 insertions(+), 44 deletions(-) diff --git a/src/main/java/com/platform/modules/live/controller/LiveSceneController.java b/src/main/java/com/platform/modules/live/controller/LiveSceneController.java index 0a023da..607bf9c 100644 --- a/src/main/java/com/platform/modules/live/controller/LiveSceneController.java +++ b/src/main/java/com/platform/modules/live/controller/LiveSceneController.java @@ -76,10 +76,10 @@ public class LiveSceneController extends AbstractController { @ApiImplicitParam(value = "页面大小", name = "pageSize", defaultValue = "15",paramType = "query", dataType = "int")}) public R page(String title, Integer sceneType, String ltype,Integer liveState, Integer pageNo, Integer pageSize, Long tenantId){ if(StringUtils.isNotBlank(ltype) && (ltype=="prod" || ltype.equals("prod"))){ - Page page = liveSceneService.pageProd(title, sceneType, ltype,liveState, null==pageNo?0:pageNo, null==pageSize?15:pageSize, tenantId); + Page page = liveSceneService.pageProd(title, 5, ltype,liveState, null==pageNo?0:pageNo, null==pageSize?15:pageSize, tenantId); return R.ok().put("page", page); }else{ - Page page = liveSceneService.page(title, sceneType, ltype,liveState, null==pageNo?0:pageNo, null==pageSize?15:pageSize, tenantId); + Page page = liveSceneService.page(title, 5, ltype,liveState, null==pageNo?0:pageNo, null==pageSize?15:pageSize, tenantId); return R.ok().put("page", page); } } @@ -116,7 +116,6 @@ public class LiveSceneController extends AbstractController { @RequiresPermissions("live:livescene:save") @ApiOperation(value = "现场保存接口", notes = "现场保存接口", produces = MediaType.APPLICATION_JSON_VALUE) public R save(@RequestBody SceneEntityVo liveScene){ - System.out.println(liveScene.toString()); try { liveScene.setCreatorId(null!=getUserId()?getUserId().intValue():null); liveSceneService.save(liveScene); @@ -138,11 +137,13 @@ public class LiveSceneController extends AbstractController { @RequiresPermissions("live:livescene:update") @ApiOperation("现场更新接口") @LiveTenant - public R update(@ModelAttribute SceneEntityVo liveScene){ + public R update(@RequestBody SceneEntityVo liveScene){ String r = null; try { r = liveSceneService.update(liveScene, getUser()); - } catch (Exception e) { + } catch (RRException e) { + return R.error("栏目只能单选"); + } catch (Exception e) { e.printStackTrace(); return R.error("系统内部错误"); } diff --git a/src/main/java/com/platform/modules/live/service/impl/LiveSceneServiceImpl.java b/src/main/java/com/platform/modules/live/service/impl/LiveSceneServiceImpl.java index 76cb84d..2c9bfdc 100644 --- a/src/main/java/com/platform/modules/live/service/impl/LiveSceneServiceImpl.java +++ b/src/main/java/com/platform/modules/live/service/impl/LiveSceneServiceImpl.java @@ -597,6 +597,14 @@ public class LiveSceneServiceImpl extends ServiceImpl1) { + throw new RRException("栏目只能单选"); + } + + //将现场类型设置为5，混合类型 + liveScene.setSceneType(SceneConstants.SceneType.MERGE.getKey()); + // 20190221 TROY 更新校验，只读 LiveSceneEntity dbScene = this.baseMapper.selectById(liveScene.getId()); if (null == dbScene) { @@ -631,7 +639,7 @@ public class LiveSceneServiceImpl extends ServiceImpl infoEntities = liveSceneLiveInfoService - .selectList(new EntityWrapper().eq("scene_id", entity.getId())); - - // 更新现场源地址 - if (infoEntities != null) { - for (LiveSceneLiveInfoEntity infoEntity : infoEntities) { - if(infoEntity==null || infoEntity.getId()==null || infoEntity.getPushState().equals(1)){ - if(StringUtils.isNotBlank(str)){ - str += ","; - } - str += infoEntity.getInfoName(); - continue; - } - LiveStreams streams = liveClient.liveStream().generateStreamUrls(infoEntity.getAppName(), - infoEntity.getStreamName(), entity.getLiveEnd()); - LiveSceneLiveInfoExtEntity extEntity = liveSceneLiveInfoExtService - .selectByInfoId(infoEntity.getId()); - if (extEntity != null) { - extEntity.setPushUrl(streams.getPushStreamUrl()); - extEntity.setPlayUrlRmtp(streams.getLiveStreamUrls()[0]); - extEntity.setPlayUrlFlv(streams.getLiveStreamUrls()[1]); - extEntity.setPlayUrlHls(streams.getLiveStreamUrls()[2]); - liveSceneLiveInfoExtService.updateById(extEntity); - } - - } - } - } - if(StringUtils.isNotBlank(str)){ - str = "现场修改成功，但流名称为："+str + "正在直播中，直播流的有效期不能进行修改"; - }else{ - str = "现场修改成功"; - } +// if (isProduct && SceneConstants.SceneType.isAllowLive(dbScene.getSceneType()) +// && !liveScene.getLiveEnd().equals(dbScene.getLiveEnd())) { +// List infoEntities = liveSceneLiveInfoService +// .selectList(new EntityWrapper().eq("scene_id", entity.getId())); +// +// // 更新现场源地址 +// if (infoEntities != null) { +// for (LiveSceneLiveInfoEntity infoEntity : infoEntities) { +// if(infoEntity==null || infoEntity.getId()==null || infoEntity.getPushState().equals(1)){ +// if(StringUtils.isNotBlank(str)){ +// str += ","; +// } +// str += infoEntity.getInfoName(); +// continue; +// } +// LiveStreams streams = liveClient.liveStream().generateStreamUrls(infoEntity.getAppName(), +// infoEntity.getStreamName(), entity.getLiveEnd()); +// LiveSceneLiveInfoExtEntity extEntity = liveSceneLiveInfoExtService +// .selectByInfoId(infoEntity.getId()); +// if (extEntity != null) { +// extEntity.setPushUrl(streams.getPushStreamUrl()); +// extEntity.setPlayUrlRmtp(streams.getLiveStreamUrls()[0]); +// extEntity.setPlayUrlFlv(streams.getLiveStreamUrls()[1]); +// extEntity.setPlayUrlHls(streams.getLiveStreamUrls()[2]); +// liveSceneLiveInfoExtService.updateById(extEntity); +// } +// +// } +// } +// } +// if(StringUtils.isNotBlank(str)){ +// str = "现场修改成功，但流名称为："+str + "正在直播中，直播流的有效期不能进行修改"; +// }else{ +// str = "现场修改成功"; +// } + str = "现场修改成功"; return str; } @@ -2510,6 +2518,11 @@ public class LiveSceneServiceImpl extends ServiceImpl channelsId) { List entityList = liveSceneChannelService.selectList(new EntityWrapper().eq("scene_id", liveScene.getId())); List oldChannelIdList = new ArrayList<>(); diff --git a/src/main/java/com/platform/modules/live/service/impl/LuceneServiceImpl.java b/src/main/java/com/platform/modules/live/service/impl/LuceneServiceImpl.java index ec8a520..2d0e40e 100644 --- a/src/main/java/com/platform/modules/live/service/impl/LuceneServiceImpl.java +++ b/src/main/java/com/platform/modules/live/service/impl/LuceneServiceImpl.java @@ -382,7 +382,7 @@ public class LuceneServiceImpl implements LuceneService { } } - private void dirCheck(String filePath) { + private void dirCheck(String filePath) { File file = new File(filePath); if (!file.exists()) { file.mkdirs(); diff --git a/src/main/java/com/platform/modules/live/vo/SceneEntityVo.java b/src/main/java/com/platform/modules/live/vo/SceneEntityVo.java index b384286..51e32d5 100644 --- a/src/main/java/com/platform/modules/live/vo/SceneEntityVo.java +++ b/src/main/java/com/platform/modules/live/vo/SceneEntityVo.java @@ -306,6 +306,11 @@ public class SceneEntityVo { this.tenantName = entity.getTenantName(); this.isAutoLive = entity.getIsAutoLive(); + + this.carouselImage = entity.getCarouselImage(); + this.viewerCount = entity.getViewerCount(); + this.likeDisplay = entity.getLikeDisplay(); + this.vrLive = entity.getVrLive(); } public Integer getId() { diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml index cc59b7d..041bde1 100644 --- a/src/main/resources/application.yml +++ b/src/main/resources/application.yml @@ -114,6 +114,7 @@ foreign: wapurl: http://zklive.zhongkedongxin.com dataurl: http://zklive.zhongkedongxin.com # mediaurl: http://test.vod.zhongkedongxin.com + #TitleImage标题图地址、视频地址url拼接，前缀 mediaurl: https://v.livejinan.cn vodmediaurl: http://test.vod.zhongkedongxin.com platform: