From 11ecb9ee39fc61af04cd8d462faf9dce496d1773 Mon Sep 17 00:00:00 2001 From: xuhy <3313886187@qq.com> Date: 星期四, 11 九月 2025 15:19:53 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TSysLiveController.java | 123 ++++++++++++++++++++++++++++++++++++++++ 1 files changed, 121 insertions(+), 2 deletions(-) diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TSysLiveController.java b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TSysLiveController.java index ef913d4..004cb54 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TSysLiveController.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TSysLiveController.java @@ -1,8 +1,25 @@ package com.ruoyi.web.controller.api; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RestController; +import com.baomidou.mybatisplus.core.toolkit.Wrappers; +import com.ruoyi.common.annotation.Log; +import com.ruoyi.common.basic.PageInfo; +import com.ruoyi.common.core.domain.R; +import com.ruoyi.common.enums.BusinessType; +import com.ruoyi.common.utils.SecurityUtils; +import com.ruoyi.framework.web.service.TokenService; +import com.ruoyi.system.model.TSysLive; +import com.ruoyi.system.query.TSysLiveQuery; +import com.ruoyi.system.service.TSysLiveService; +import com.ruoyi.system.vo.TSysLiveVO; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.validation.annotation.Validated; +import org.springframework.web.bind.annotation.*; + +import java.time.LocalDateTime; +import java.util.List; /** * <p> @@ -12,9 +29,111 @@ * @author xiaochen * @since 2025-08-20 */ +@Api(tags = "直播管理") @RestController @RequestMapping("/t-sys-live") public class TSysLiveController { + private final TSysLiveService sysLiveService; + private final TokenService tokenService; + @Autowired + public TSysLiveController(TSysLiveService sysLiveService, TokenService tokenService) { + this.sysLiveService = sysLiveService; + this.tokenService = tokenService; + } + + /** + * 获取直播管理管理列表 + */ + @ApiOperation(value = "获取直播管理分页列表") + @PostMapping(value = "/pageList") + public R<PageInfo<TSysLiveVO>> pageList(@RequestBody TSysLiveQuery query) { + return R.ok(sysLiveService.pageList(query)); + } + + /** + * 获取直播管理管理列表 + */ + @ApiOperation(value = "获取直播管理列表") + @PostMapping(value = "/list") + public R<List<TSysLive>> list() { + return R.ok(sysLiveService.list(Wrappers.lambdaQuery(TSysLive.class).orderByDesc(TSysLive::getCreateTime))); + } + + /** + * 添加直播管理管理 + */ + @Log(title = "直播管理信息-新增直播管理", businessType = BusinessType.INSERT) + @ApiOperation(value = "添加直播管理") + @PostMapping(value = "/add") + public R<Boolean> add(@Validated @RequestBody TSysLive dto) { + // 直播开始时间无法小于当前时间 + if (dto.getStartTime().isBefore(LocalDateTime.now())) { + return R.fail("直播开始时间无法小于当前时间"); + } + // 计算结束时间 + dto.setEndTime(dto.getStartTime().plusMinutes(dto.getExpectedDuration())); + dto.setPassword(SecurityUtils.encryptPassword(dto.getPassword())); + return R.ok(sysLiveService.save(dto)); + } + + /** + * 修改直播管理 + */ + @Log(title = "直播管理信息-修改直播管理", businessType = BusinessType.UPDATE) + @ApiOperation(value = "修改直播管理") + @PostMapping(value = "/update") + public R<Boolean> update(@Validated @RequestBody TSysLive dto) { + // 直播已开始无法编辑 +// if (dto.getStartTime().isBefore(LocalDateTime.now())) { +// return R.fail("直播已开始,无法编辑"); +// } + // 计算结束时间 + dto.setEndTime(dto.getStartTime().plusMinutes(dto.getExpectedDuration())); + dto.setPassword(SecurityUtils.encryptPassword(dto.getPassword())); + return R.ok(sysLiveService.updateById(dto)); + } + + /** + * 查看直播管理详情 + */ + @ApiOperation(value = "查看直播管理详情") + @GetMapping(value = "/getDetailById") + public R<TSysLive> getDetailById(@RequestParam String id) { + return R.ok(sysLiveService.getById(id)); + } + + /** + * 删除直播管理 + */ + @Log(title = "直播管理信息-删除直播管理", businessType = BusinessType.DELETE) + @ApiOperation(value = "删除直播管理") + @DeleteMapping(value = "/deleteById") + public R<Boolean> deleteById(@RequestParam String id) { + return R.ok(sysLiveService.removeById(id)); + } + + /** + * 批量删除直播管理 + */ + @Log(title = "直播管理信息-删除直播管理", businessType = BusinessType.DELETE) + @ApiOperation(value = "批量删除直播管理") + @DeleteMapping(value = "/deleteByIds") + public R<Boolean> deleteByIds(@RequestBody List<String> ids) { + return R.ok(sysLiveService.removeByIds(ids)); + } + + /** + * 直播管理推送用户 + */ + @Log(title = "直播管理信息-推送用户", businessType = BusinessType.UPDATE) + @ApiOperation(value = "直播管理信息推送用户") + @PutMapping(value = "/pushUser") + public R<String> pushUser(@RequestParam(value = "id") String id, + @RequestParam(value = "pushType")String pushType) { + sysLiveService.pushUser(id,pushType); + return R.ok(); + } + } -- Gitblit v1.7.1