feat: add video platform config

+package org.thingsboard.server.controller.yunteng;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.RequiredArgsConstructor;
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.*;
+import org.thingsboard.server.common.data.exception.ThingsboardException;
+import org.thingsboard.server.common.data.yunteng.common.DeleteGroup;
+import org.thingsboard.server.common.data.yunteng.dto.DeleteDTO;
+import org.thingsboard.server.common.data.yunteng.dto.YtVideoPlatformDTO;
+import org.thingsboard.server.common.data.yunteng.enums.OrderTypeEnum;
+import org.thingsboard.server.common.data.yunteng.utils.tools.YtPageData;
+import org.thingsboard.server.controller.BaseController;
+import org.thingsboard.server.dao.yunteng.entities.YtVideoPlatformEntity;
+import org.thingsboard.server.dao.yunteng.service.YtVideoPlatformService;
+
+import static org.thingsboard.server.common.data.yunteng.constant.QueryConstant.*;
+
+@RestController
+@RequestMapping("api/yt/video/platform")
+@Api(tags = {"流媒体平台配置"})
+@RequiredArgsConstructor
+@PreAuthorize("hasAnyAuthority('TENANT_ADMIN','CUSTOMER_USER')")
+public class YtVideoPlatformController extends BaseController {
+
+    private final YtVideoPlatformService videoPlatformService;
+
+    @GetMapping(params = {PAGE_SIZE, PAGE})
+    @ApiOperation("分页")
+    public YtPageData<YtVideoPlatformDTO> pageVideoPlatform(
+            @RequestParam(PAGE_SIZE) int pageSize,
+            @RequestParam(PAGE) int page,
+            @RequestParam(value = "host", required = false) String host,
+            @RequestParam(value = ORDER_FILED, required = false) String orderBy,
+            @RequestParam(value = ORDER_TYPE, required = false) OrderTypeEnum orderType)
+            throws ThingsboardException {
+
+
+        IPage<YtVideoPlatformEntity> pageInfo = videoPlatformService.getPage(page, pageSize, orderBy, orderType);
+        return videoPlatformService.page(pageInfo, getCurrentUser().isPtTenantAdmin(),
+                getCurrentUser().getCurrentTenantId(),
+                getCurrentUser().getCurrentUserId(), host);
+    }
+
+    @PostMapping
+    @ApiOperation("新增|编辑")
+    public YtVideoPlatformDTO saveOrUpdateVideoPlatform(
+            @Validated @RequestBody YtVideoPlatformDTO dto) throws ThingsboardException {
+        dto.setTenantId(getCurrentUser().getCurrentTenantId());
+        return videoPlatformService.saveOrUpdate(dto);
+    }
+
+    @DeleteMapping
+    @ApiOperation("删除")
+    public boolean deleteVideoPlatform(@Validated(DeleteGroup.class) @RequestBody DeleteDTO deleteDTO)
+            throws ThingsboardException {
+        deleteDTO.setTenantId(getCurrentUser().getCurrentTenantId());
+        return videoPlatformService.deleteDataByIds(deleteDTO);
+    }
+}

@@ -45,8 +45,6 @@ public final class ModelConstants {
         "iotfs_user_organization_mapping";
     /** 设备表 */
     public static final String IOTFS_DEVICE_TABLE_NAME = "iotfs_device";
-    /** 设备配置表 */
-    public static final String IOTFS_DEVICE_PROFILE_TABLE_NAME = "iotfs_device_profile";
     /** 设备类型表 */
     public static final String IOTFS_DEVICE_TYPE_TABLE_NAME = "iotfs_device_type";
     /** 告警配置表 */
@@ -83,6 +81,8 @@ public final class ModelConstants {
     public static final String IOTFS_CONFIGURATION_ACT = "iotfs_configuration_act";
     /** 视频流 */
     public static final String IOTFS_VIDEO_STREAM_TABLE_NAME = "iotfs_device_camera";
+    /** 流媒体配置 */
+    public static final String IOTFS_VIDEO_PLATFORM_TABLE_NAME = "iotfs_video_platform";
     /** 意见反馈 */
     public static final String IOTFS_OPINION_TABLE_NAME = "iotfs_opinion";
     /** 第三方用户表 */

@@ -63,6 +63,7 @@ public enum ErrorMessage {
   APP_USER_BINDED(400043,"平台用户【%s】已被其它账号绑定"),
   THIRD_PLATFORM_EXCEPTION(400044,"【%s】，第三方异常【%s】"),
   DEVICE_NOT_EXTIED(400045,"设备不存在"),
+  VIDEO_PLATFORM_HOST_EXISTED(400046,"流媒体平台地址已存在"),
   HAVE_NO_PERMISSION(500002,"没有修改权限");
   private final int code;
   private String message;

+package org.thingsboard.server.common.data.yunteng.dto;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import javax.validation.constraints.Max;
+import javax.validation.constraints.NotEmpty;
+import javax.validation.constraints.NotNull;
+import javax.validation.constraints.Size;
+
+@Data
+@EqualsAndHashCode(callSuper = true)
+public class YtVideoPlatformDTO extends TenantDTO {
+    @ApiModelProperty(value = "平台类型",required = true)
+    @NotNull(message = "平台类型不能为空")
+    @Max(value = 2,message = "平台类型最大长度2")
+    private Integer type;
+
+    @ApiModelProperty(value = "平台地址+端口",required = true)
+    @NotEmpty(message = "平台地址+端口不能为空")
+    @Size(max = 36,message = "平台地址最大长度36")
+    private String host;
+
+    @ApiModelProperty(value = "秘钥appKey", required = true)
+    @NotEmpty(message = "秘钥appKey不能为空")
+    @Size(max = 36,message = "appKey最大长度36")
+    private String appKey;
+
+    @ApiModelProperty(value = "秘钥appSecret", required = true)
+    @NotEmpty(message = "秘钥appSecret不能为空")
+    @Size(max = 36,message = "appSecret最大长度36")
+    private String appSecret;
+
+    @ApiModelProperty(value = "流媒体部署环境",required = true)
+    @NotNull(message = "流媒体部署环境不能为空")
+    @Max(value = 2,message = "平台类型最大长度2")
+    private Integer ssl;
+
+}

+package org.thingsboard.server.dao.yunteng.entities;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.thingsboard.server.common.data.yunteng.constant.ModelConstants;
+
+/**
+ * @author Administrator
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@TableName(ModelConstants.Table.IOTFS_VIDEO_PLATFORM_TABLE_NAME)
+public class YtVideoPlatformEntity extends TenantBaseEntity {
+
+
+    private static final long serialVersionUID = 2003070844243253804L;
+    private Integer type;
+    private String host;
+    private String appKey;
+    private String appSecret;
+    private Integer ssl;
+}

+package org.thingsboard.server.dao.yunteng.impl;
+
+import com.baomidou.mybatisplus.core.conditions.Wrapper;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.thingsboard.server.common.data.StringUtils;
+import org.thingsboard.server.common.data.yunteng.core.exception.YtDataValidationException;
+import org.thingsboard.server.common.data.yunteng.core.message.ErrorMessage;
+import org.thingsboard.server.common.data.yunteng.dto.DeleteDTO;
+import org.thingsboard.server.common.data.yunteng.dto.YtVideoPlatformDTO;
+import org.thingsboard.server.common.data.yunteng.utils.tools.YtPageData;
+import org.thingsboard.server.dao.yunteng.entities.YtVideoPlatformEntity;
+import org.thingsboard.server.dao.yunteng.mapper.YtVideoPlatformMapper;
+import org.thingsboard.server.dao.yunteng.service.AbstractBaseService;
+import org.thingsboard.server.dao.yunteng.service.YtVideoPlatformService;
+
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class YtVideoPlatformServiceImpl extends AbstractBaseService<YtVideoPlatformMapper, YtVideoPlatformEntity>
+        implements YtVideoPlatformService {
+
+    @Override
+    public YtPageData<YtVideoPlatformDTO> page(IPage<YtVideoPlatformEntity> pageInfo,
+                                               boolean isPtTenantAdmin, String tenantId, String currentUserId, String host) {
+        IPage<YtVideoPlatformDTO> page =
+                baseMapper.getVideoPlatformPage(pageInfo, tenantId, host);
+        return getPageData(page, YtVideoPlatformDTO.class);
+    }
+
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public YtVideoPlatformDTO saveOrUpdate(YtVideoPlatformDTO videoPlatformDTO) {
+        if (StringUtils.isNotEmpty(videoPlatformDTO.getId())) {
+            Wrapper filter = new QueryWrapper<YtVideoPlatformEntity>().lambda()
+                    .eq(YtVideoPlatformEntity::getTenantId, videoPlatformDTO.getTenantId())
+                    .eq(YtVideoPlatformEntity::getId, videoPlatformDTO.getId());
+            YtVideoPlatformEntity oldVideo = baseMapper.selectOne(filter);
+            if (null == oldVideo) {
+                throw new YtDataValidationException(String.format(ErrorMessage.NOT_EXITED_OR_PERMISSION.getMessage(),
+                        videoPlatformDTO.getId()));
+            }
+            baseMapper.updateById(videoPlatformDTO.getEntity(YtVideoPlatformEntity.class));
+        } else {
+            YtVideoPlatformEntity entity = baseMapper.selectOne(new LambdaQueryWrapper<YtVideoPlatformEntity>().
+                    eq(YtVideoPlatformEntity::getHost, videoPlatformDTO.getHost()));
+            if (null != entity) {
+                throw new YtDataValidationException(ErrorMessage.VIDEO_PLATFORM_HOST_EXISTED.getMessage());
+            }
+            baseMapper.insert(videoPlatformDTO.getEntity(YtVideoPlatformEntity.class));
+        }
+        return videoPlatformDTO;
+    }
+
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public boolean deleteDataByIds(DeleteDTO deleteDTO) {
+        Wrapper<YtVideoPlatformEntity> filter = new QueryWrapper<YtVideoPlatformEntity>().lambda()
+                .eq(YtVideoPlatformEntity::getTenantId, deleteDTO.getTenantId())
+                .in(YtVideoPlatformEntity::getId, deleteDTO.getIds());
+        return baseMapper.delete(filter) > 0;
+    }
+
+}

+package org.thingsboard.server.dao.yunteng.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.thingsboard.server.common.data.yunteng.dto.YtVideoPlatformDTO;
+import org.thingsboard.server.dao.yunteng.entities.YtVideoPlatformEntity;
+
+
+/**
+ * @author Administrator
+ */
+@Mapper
+public interface YtVideoPlatformMapper extends BaseMapper<YtVideoPlatformEntity> {
+    /**
+     * @param page
+     * @param tenantId
+     * @return
+     */
+    IPage<YtVideoPlatformDTO> getVideoPlatformPage(IPage<?> page, @Param("tenantId") String tenantId, @Param("host") String host);
+}

+package org.thingsboard.server.dao.yunteng.service;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import org.thingsboard.server.common.data.yunteng.dto.DeleteDTO;
+import org.thingsboard.server.common.data.yunteng.dto.YtVideoPlatformDTO;
+import org.thingsboard.server.common.data.yunteng.utils.tools.YtPageData;
+import org.thingsboard.server.dao.yunteng.entities.YtVideoPlatformEntity;
+
+public interface YtVideoPlatformService extends BaseService<YtVideoPlatformEntity> {
+
+    /**
+     * @param pageInfo        分页配置信息
+     * @param isPtTenantAdmin 是否平台管理员
+     * @param tenantId        租户ID
+     * @param currentUserId   用户ID
+     * @param host            流媒体地址
+     * @return
+     */
+    YtPageData<YtVideoPlatformDTO> page(IPage<YtVideoPlatformEntity> pageInfo,
+                                        boolean isPtTenantAdmin, String tenantId, String currentUserId, String host);
+
+    /**
+     * @param dto
+     * @return
+     */
+    YtVideoPlatformDTO saveOrUpdate(YtVideoPlatformDTO dto);
+
+    /**
+     * @param deleteDTO
+     * @return
+     */
+    boolean deleteDataByIds(DeleteDTO deleteDTO);
+
+}

+<?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="org.thingsboard.server.dao.yunteng.mapper.YtVideoPlatformMapper">
+    <resultMap type="org.thingsboard.server.common.data.yunteng.dto.YtVideoPlatformDTO" id="videoPlatformMap">
+        <result property="id" column="id"/>
+        <result property="type" column="type"/>
+        <result property="host" column="host"/>
+        <result property="appKey" column="app_key"/>
+        <result property="appSecret" column="app_secret"/>
+        <result property="ssl" column="ssl"/>
+        <result property="tenantId" column="tenant_id"/>
+        <result property="createTime" column="create_time"/>
+        <result property="updateTime" column="update_time"/>
+        <result property="creator" column="creator"/>
+        <result property="updater" column="updater"/>
+    </resultMap>
+
+    <sql id="basicColumns">
+        base.id,base.type,base.host,base.app_key,base.app_secret,base.ssl,base.tenant_id,base.create_time,
+        base.update_time,base.creator, base.updater
+    </sql>
+    <select id="getVideoPlatformPage" resultMap="videoPlatformMap">
+        SELECT
+        <include refid="basicColumns"/>
+        FROM iotfs_video_platform base
+        <where>
+            <if test="tenantId !=null and tenantId !=''">
+                AND base.tenant_id = #{tenantId}
+            </if>
+            <if test="host !=null and host !=''">
+                AND base.host LIKE concat('%',#{host}::TEXT,'%')
+            </if>
+        </where>
+    </select>
+</mapper>