代码生成

iot-module/iot-module-stream/iot-module-stream-biz/src/main/java/com/middle/platform/stream/biz/entity/SDevice.java

@@ -0,0 +1,100 @@
+package com.middle.platform.stream.biz.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Getter;
+import lombok.Setter;
+
+import java.time.LocalDateTime;
+
+/**
+* @date 2024-05-06 09:54:48
+* @author xucaiqin
+*/
+@Getter
+@Setter
+@TableName(value = "s_device")
+public class SDevice {
+    /**
+     * id
+     */
+    @TableId(value = "id", type = IdType.ASSIGN_ID)
+    private Long id;
+
+    /**
+     * 设备id
+     */
+    @TableField(value = "device_id")
+    private Long deviceId;
+
+    /**
+     * 封面地址
+     */
+    @TableField(value = "cover")
+    private String cover;
+
+    /**
+     * 流路径
+     */
+    @TableField(value = "`path`")
+    private String path;
+
+    /**
+     * 目标地址
+     */
+    @TableField(value = "target")
+    private String target;
+
+    /**
+     * 分片存储规则 1-1小时
+     */
+    @TableField(value = "save_rule")
+    private Boolean saveRule;
+
+    /**
+     * 使用状态 1-使用中 2-禁用
+     */
+    @TableField(value = "use_flag")
+    private Boolean useFlag;
+
+    /**
+     * 视频流类型 1-rtsp 2-rtmp
+     */
+    @TableField(value = "`type`")
+    private Boolean type;
+
+    /**
+     * 创建人
+     */
+    @TableField(value = "create_by")
+    private Long createBy;
+
+    /**
+     * 创建时间
+     */
+    @TableField(value = "create_time")
+    private LocalDateTime createTime;
+
+    /**
+     * 更新人
+     */
+    @TableField(value = "update_by")
+    private Long updateBy;
+
+    /**
+     * 更新时间
+     */
+    @TableField(value = "update_time")
+    private LocalDateTime updateTime;
+
+    @TableField(value = "delete_time")
+    private LocalDateTime deleteTime;
+
+    /**
+     * 删除标识
+     */
+    @TableField(value = "del_flag")
+    private Integer delFlag;
+}

iot-module/iot-module-stream/iot-module-stream-biz/src/main/java/com/middle/platform/stream/biz/mapper/SDeviceMapper.java

@@ -0,0 +1,13 @@
+package com.middle.platform.stream.biz.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.middle.platform.stream.biz.entity.SDevice;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+* @date 2024-05-06 09:54:48
+* @author xucaiqin
+*/
+@Mapper
+public interface SDeviceMapper extends BaseMapper<SDevice> {
+}

iot-module/iot-module-stream/iot-module-stream-biz/src/main/java/com/middle/platform/stream/biz/service/SDeviceService.java

@@ -0,0 +1,14 @@
+package com.middle.platform.stream.biz.service;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.middle.platform.stream.biz.entity.SDevice;
+import com.middle.platform.stream.biz.mapper.SDeviceMapper;
+import org.springframework.stereotype.Service;
+/**
+* @date 2024-05-06 09:54:48
+* @author xucaiqin
+*/
+@Service
+public class SDeviceService extends ServiceImpl<SDeviceMapper, SDevice> {
+
+}

iot-module/iot-module-stream/iot-module-stream-biz/src/main/java/com/middle/platform/stream/biz/service/impl/StreamMediaServiceImpl.java

@@ -22,8 +22,9 @@ public class StreamMediaServiceImpl implements StreamMediaService {
 
     @Override
     public List<Object> rtmpPage(StreamPage streamPage) {
-        //todo yewuku
-        //fenye
+        //根据设备名称模糊筛选设备，获得设备id列表
+        String keywords = streamPage.getKeywords();
+        //
         ArrayList<Object> objects = new ArrayList<>();
 
         Object o = apiProxy.rtmpList();

iot-module/iot-module-stream/iot-module-stream-biz/src/main/resources/mapper/SDeviceMapper.xml

@@ -0,0 +1,27 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.middle.platform.stream.biz.mapper.SDeviceMapper">
+  <resultMap id="BaseResultMap" type="com.middle.platform.stream.biz.entity.SDevice">
+    <!--@mbg.generated-->
+    <!--@Table s_device-->
+    <id column="id" jdbcType="BIGINT" property="id" />
+    <result column="device_id" jdbcType="BIGINT" property="deviceId" />
+    <result column="cover" jdbcType="VARCHAR" property="cover" />
+    <result column="path" jdbcType="VARCHAR" property="path" />
+    <result column="target" jdbcType="VARCHAR" property="target" />
+    <result column="save_rule" jdbcType="BOOLEAN" property="saveRule" />
+    <result column="use_flag" jdbcType="BOOLEAN" property="useFlag" />
+    <result column="type" jdbcType="BOOLEAN" property="type" />
+    <result column="create_by" jdbcType="BIGINT" property="createBy" />
+    <result column="create_time" jdbcType="TIMESTAMP" property="createTime" />
+    <result column="update_by" jdbcType="BIGINT" property="updateBy" />
+    <result column="update_time" jdbcType="TIMESTAMP" property="updateTime" />
+    <result column="delete_time" jdbcType="TIMESTAMP" property="deleteTime" />
+    <result column="del_flag" jdbcType="TINYINT" property="delFlag" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    <!--@mbg.generated-->
+    id, device_id, cover, `path`, target, save_rule, use_flag, `type`, create_by, create_time, 
+    update_by, update_time, delete_time, del_flag
+  </sql>
+</mapper>