wanghongbo

entity+mapper

package com.wondertek.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
/**
* 垫片配置表实体类
* 对应表结构:crp_backup_config
*/
@Data
@TableName("crp_backup_config")
public class BackupConfig {
/** 主键 */
@TableId(type = IdType.AUTO)
private Long id;
/** 审片间ID */
private Long roomId;
/** 垫片ID */
private Long backupId;
/** 垫片地址 */
private String backupPath;
/** 垫片序号 */
private Integer backupOrder;
// Getter 和 Setter 方法
}
\ No newline at end of file
... ...
... ... @@ -18,7 +18,7 @@ import java.util.Date;
*/
@Data
@TableName("crp_backup_material")
public class CrpBackupMaterial extends Model<CrpBackupMaterial> {
public class BackupMaterial extends Model<BackupMaterial> {
/** id */
@TableId
private Long id ;
... ...
package com.wondertek.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import java.time.LocalDateTime;
/**
* 审片间表实体类
*/
@Data
@TableName("crp_live_monitor_room")
public class LiveMonitorRoom {
/** 审片间ID */
@TableId(type = IdType.AUTO)
private Long id;
/** 审片间名称 */
private String name;
/** 播控状态 0-播放中 1-已屏蔽 */
private String brocStatus;
/** 审片间状态 0-启用 1-禁用 */
private String roomStatus;
/** 是否删除 0-否 1-是 */
private String del;
/** 创建人 */
private String createdBy;
/** 创建时间 */
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
private LocalDateTime createdTime;
/** 更新人 */
private String updatedBy;
/** 更新时间 */
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
private LocalDateTime updatedTime;
/** 多画输出流地址 */
private String mixOutputUrl;
}
\ No newline at end of file
... ...
package com.wondertek.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import java.time.LocalDateTime;
/**
* @description 标记表
* @author W5669
* @date 2025/7/21 10:22
*/
@Data
@TableName("crp_monitor_mark")
public class MonitorMark {
/**
* id
*/
@TableId(type = IdType.AUTO)
private Long id;
/**
* 审片间id
*/
private Long roomId;
/**
* 任务Id
*/
private String taskId;
/**
* 操作人
*/
private String createdBy;
/**
* 操作时间
*/
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
private LocalDateTime createdTime;
/**
* 标记起始时间
*/
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
private LocalDateTime markStartTime;
/**
* 标记结束时间
*/
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
private LocalDateTime markEndTime;
}
\ No newline at end of file
... ...
package com.wondertek.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import java.time.LocalDateTime;
/**
* 操作日志表实体类
*/
@Data
@TableName("crp_operation_log")
public class OperationLog {
/** 日志ID */
@TableId (type = IdType.AUTO)
private Long id;
/** 业务ID */
private String businesId;
/** 业务类型(如 cloudMonitor-云审片) */
private String businessType;
/** 操作类型(音画屏蔽、画面屏蔽、恢复、延时、标记) */
private String operationType;
/** 操作人 */
private String createdBy;
/** 操作时间 */
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
private LocalDateTime createdTime;
/** 请求路径 */
private String requestUrl;
/** 请求参数 */
private String param;
/** 响应结果 */
private String reponseResult;
/** 响应码 */
private String reponseCode;
/** 操作状态(0-成功 1-失败) */
private String status;
}
\ No newline at end of file
... ...
package com.wondertek.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import java.time.LocalDateTime;
/**
* 审片间关联任务实体类
* <p>对应数据库表:crp_stream_task</p>
*/
@Data
@TableName("crp_stream_task")
public class StreamTask {
/**
* 主键ID(自增)
* <p>唯一标识审片任务记录</p>
*/
@TableId(type = IdType.AUTO)
private Long id;
/**
* 频道唯一标识
* <p>关联转码平台的频道ID</p>
*/
private String taskId;
/** 转码平台频道ID */
private Long channelId;
/** 关联的审片间ID */
private Long roomId;
/**
* 任务类型
* <p>取值:</p>
* <ul>
* <li>"0" - 主任务</li>
* <li>"1" - 备任务</li>
* </ul>
*/
private String taskType;
/**
* 延时设置(单位:秒)
* <p>表示音视频流处理的延迟时长</p>
*/
private Integer delayTime;
/**
* 播放模式
* <p>取值:</p>
* <ul>
* <li>"source" - 原始延时前流</li>
* <li>"delay1" - 第一级延时流</li>
* <li>"delay2" - 第二级延时流</li>
* <li>"play" - 最终播放流</li>
* </ul>
*/
private String playType;
/**
* 输出目录地址
* <p>存储转码后文件的路径(最大长度1024字符)</p>
*/
private String outputDir;
/** 记录创建人 */
private String createdBy;
/** 任务创建时间 */
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
private LocalDateTime createdTime;
/** 最后更新人 */
private String updatedBy;
/** 最后更新时间 */
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
private LocalDateTime updatedTime;
/** 审片任务名称 */
private String taskName;
/**
* 屏蔽状态
* <p>取值:</p>
* <ul>
* <li>"0" - 未屏蔽(默认)</li>
* <li>"1" - 已屏蔽</li>
* </ul>
*/
private String blockStatus;
/** 输出组序号(标识输出分组) */
private String outputGroup;
/**
* 多画面配置状态
* <p>取值:</p>
* <ul>
* <li>"0" - 未启用多画面</li>
* <li>"1" - 已启用多画面</li>
* </ul>
*/
private String mixConfig;
}
\ No newline at end of file
... ...
package com.wondertek.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.wondertek.entity.BackupConfig;
/**
* @Description:
* @Author W5669
* @Create 2025/7/21
* @Version 1.0
*/
public interface BackupConfigMapper extends BaseMapper<BackupConfig> {
}
... ...
package com.wondertek.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.wondertek.entity.CrpBackupMaterial;
import com.wondertek.entity.BackupMaterial;
import org.apache.ibatis.annotations.Mapper;
@Mapper
public interface CrpBackupMaterialMapper extends BaseMapper<CrpBackupMaterial> {
public interface BackupMaterialMapper extends BaseMapper<BackupMaterial> {
}
... ...
package com.wondertek.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.wondertek.entity.LiveMonitorRoom;
/**
* @Description:
* @Author W5669
* @Create 2025/7/21
* @Version 1.0
*/
public interface LiveMonitorRoomMapper extends BaseMapper<LiveMonitorRoom> {
}
... ...
package com.wondertek.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.wondertek.entity.MonitorMark;
/**
* @Description:
* @Author W5669
* @Create 2025/7/21
* @Version 1.0
*/
public interface MonitorMarkMapper extends BaseMapper<MonitorMark> {
}
... ...
package com.wondertek.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.wondertek.entity.OperationLog;
/**
* @Description:
* @Author W5669
* @Create 2025/7/21
* @Version 1.0
*/
public interface OperationLogMapper extends BaseMapper<OperationLog> {
}
... ...
package com.wondertek.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.wondertek.entity.StreamTask;
/**
* @Description:
* @Author W5669
* @Create 2025/7/21
* @Version 1.0
*/
public interface StreamTaskMapper extends BaseMapper<StreamTask> {
}
... ...
package com.wondertek.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.wondertek.dto.CrpBackupMaterialDto;
import com.wondertek.entity.CrpBackupMaterial;
import com.wondertek.mapper.CrpBackupMaterialMapper;
import com.wondertek.mapper.BackupMaterialMapper;
import com.wondertek.service.CrpBackupMaterialService;
import com.wondertek.util.PageBean;
import jakarta.annotation.Resource;
... ... @@ -15,10 +14,10 @@ import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Service;
@Service
public class CrpBackupMaterialServiceImpl extends ServiceImpl<CrpBackupMaterialMapper, CrpBackupMaterial> implements CrpBackupMaterialService {
public class CrpBackupMaterialServiceImpl extends ServiceImpl<BackupMaterialMapper, CrpBackupMaterial> implements CrpBackupMaterialService {
@Resource
private CrpBackupMaterialMapper crpBackupMaterialMapper;
private BackupMaterialMapper crpBackupMaterialMapper;
@Override
public PageBean queryPage(CrpBackupMaterialDto crpBackupMaterialDto) {
... ...