添加数据库链接信息配置增加ssl和ssh配置

@@ -429,12 +429,12 @@ COMMENT ON COLUMN qg_db_connect.connect_timeout IS '最大等待时间(毫秒)ï¼
 CREATE TABLE "qg_db_connect_ssh" (
 CREATE TABLE "qg_db_connect_ssh" (
  "id"            varchar(36) PRIMARY KEY,
  "id"            varchar(36) PRIMARY KEY,
  "connect_id"    varchar(36)  NOT NULL,
  "connect_id"    varchar(36)  NOT NULL,
- "ip"            varchar(20)  NOT NULL,
- "port"          varchar(20)  NOT NULL,
- "ssh_name"      varchar(50)  NOT NULL,
- "ssh_password"  varchar(50)  NOT NULL,
- "verify_method" varchar(200) NOT NULL,
- "private_key"   varchar(200) NOT NULL,
+ "ip"            varchar(20),
+ "port"          varchar(20),
+ "ssh_name"      varchar(50),
+ "ssh_password"  varchar(50),
+ "verify_method" varchar(200),
+ "private_key"   varchar(200),
  "tenant_id"     varchar(36),
  "tenant_id"     varchar(36),
  "create_time"   timestamp(6),
  "create_time"   timestamp(6),
  "creator"       varchar(36) NULL,
  "creator"       varchar(36) NULL,
@@ -447,44 +447,17 @@ COMMENT ON COLUMN qg_db_connect.connect_id IS 'æ•°æ®åº“链接信æ¯id';
 COMMENT ON COLUMN qg_db_connect_ssh.ip IS 'ssh的ip';
 COMMENT ON COLUMN qg_db_connect_ssh.ip IS 'ssh的ip';
 COMMENT ON COLUMN qg_db_connect_ssh.port IS 'ssh的port';
 COMMENT ON COLUMN qg_db_connect_ssh.port IS 'ssh的port';
 COMMENT ON COLUMN qg_db_connect_ssh.ssh_name IS '用户名';
 COMMENT ON COLUMN qg_db_connect_ssh.ssh_name IS '用户名';
-COMMENT ON COLUMN qg_db_connect_ssh.ssh_password IS '租户ID';
 COMMENT ON COLUMN qg_db_connect_ssh.ssh_password IS '密码/密码短语';
 COMMENT ON COLUMN qg_db_connect_ssh.ssh_password IS '密码/密码短语';
-COMMENT ON COLUMN qg_db_connect_ssh.verify_method IS '验证方式（PASSWORD：密码；PUBLIC_KEY）';
+COMMENT ON COLUMN qg_db_connect_ssh.verify_method IS '验证方式（PASSWORD：密码；PUBLIC_KEY：公钥）';
 COMMENT ON COLUMN qg_db_connect_ssh.private_key IS '私钥文件';
 COMMENT ON COLUMN qg_db_connect_ssh.private_key IS '私钥文件';
 
 
 CREATE TABLE "qg_db_connect_ssl" (
 CREATE TABLE "qg_db_connect_ssl" (
- "id"            varchar(36) PRIMARY KEY,
- "connect_id"    varchar(36)  NOT NULL,
- "ip"            varchar(20)  NOT NULL,
- "port"          varchar(20)  NOT NULL,
- "ssh_name"      varchar(50)  NOT NULL,
- "ssh_password"  varchar(50)  NOT NULL,
- "verify_method" varchar(200) NOT NULL,
- "private_key"   varchar(200) NOT NULL,
- "tenant_id"     varchar(36),
- "create_time"   timestamp(6),
- "creator"       varchar(36) NULL,
- "updater"       varchar(36) NULL,
- "update_time"   timestamp(6)
-);
-COMMENT ON TABLE qg_db_connect IS 'SSH通道配置信息';
-COMMENT ON COLUMN qg_db_connect.tenant_id IS '租户ID';
-COMMENT ON COLUMN qg_db_connect.connect_id IS '数据库链接信息id';
-COMMENT ON COLUMN qg_db_connect.ip IS 'ssh的ip';
-COMMENT ON COLUMN qg_db_connect.port IS 'ssh的port';
-COMMENT ON COLUMN qg_db_connect.ssh_name IS '用户名';
-COMMENT ON COLUMN qg_db_connect.ssh_password IS '租户ID';
-COMMENT ON COLUMN qg_db_connect.ssh_password IS '密码/密码短语';
-COMMENT ON COLUMN qg_db_connect.verify_method IS '验证方式（PASSWORD：密码；PUBLIC_KEY）';
-COMMENT ON COLUMN qg_db_connect.private_key IS '私钥文件';
-
-CREATE TABLE "qg_db_connect_ssl" (
  "id"             varchar(36) PRIMARY KEY,
  "id"             varchar(36) PRIMARY KEY,
  "connect_id"     varchar(36) NOT NULL,
  "connect_id"     varchar(36) NOT NULL,
- "ca_cert"        varchar(50) NOT NULL,
+ "ca_cert"        varchar(50),
  "verify_ca_cert" bool        NOT NULL DEFAULT FALSE,
  "verify_ca_cert" bool        NOT NULL DEFAULT FALSE,
- "client_key"     varchar(50) NOT NULL,
- "client_cert"    varchar(50) NOT NULL,
+ "client_key"     varchar(50),
+ "client_cert"    varchar(50),
  "tenant_id"      varchar(36),
  "tenant_id"      varchar(36),
  "create_time"    timestamp(6),
  "create_time"    timestamp(6),
  "creator"        varchar(36) NULL,
  "creator"        varchar(36) NULL,

@@ -1161,12 +1161,12 @@ CREATE TABLE IF NOT EXISTS qg_db_connect (
 CREATE TABLE IF NOT EXISTS qg_db_connect_ssl (
 CREATE TABLE IF NOT EXISTS qg_db_connect_ssl (
     "id"            varchar(36) PRIMARY KEY,
     "id"            varchar(36) PRIMARY KEY,
     "connect_id"    varchar(36)  NOT NULL,
     "connect_id"    varchar(36)  NOT NULL,
-    "ip"            varchar(20)  NOT NULL,
-    "port"          varchar(20)  NOT NULL,
-    "ssh_name"      varchar(50)  NOT NULL,
-    "ssh_password"  varchar(50)  NOT NULL,
-    "verify_method" varchar(200) NOT NULL,
-    "private_key"   varchar(200) NOT NULL,
+    "ip"            varchar(20),
+    "port"          varchar(20),
+    "ssh_name"      varchar(50),
+    "ssh_password"  varchar(50),
+    "verify_method" varchar(200),
+    "private_key"   varchar(200),
     "tenant_id"     varchar(36),
     "tenant_id"     varchar(36),
     "create_time"   timestamp(6),
     "create_time"   timestamp(6),
     "creator"       varchar(36) NULL,
     "creator"       varchar(36) NULL,
@@ -1176,11 +1176,11 @@ CREATE TABLE IF NOT EXISTS qg_db_connect_ssl (
 
 
 CREATE TABLE IF NOT EXISTS qg_db_connect_ssl (
 CREATE TABLE IF NOT EXISTS qg_db_connect_ssl (
     "id"             varchar(36) PRIMARY KEY,
     "id"             varchar(36) PRIMARY KEY,
-    "connect_id"     varchar(36) NOT NULL,
-    "ca_cert"        varchar(50) NOT NULL,
+    "connect_id"     varchar(36,
+    "ca_cert"        varchar(50),
     "verify_ca_cert" bool        NOT NULL DEFAULT FALSE,
     "verify_ca_cert" bool        NOT NULL DEFAULT FALSE,
-    "client_key"     varchar(50) NOT NULL,
-    "client_cert"    varchar(50) NOT NULL,
+    "client_key"     varchar(50),
+    "client_cert"    varchar(50),
     "tenant_id"      varchar(36),
     "tenant_id"      varchar(36),
     "create_time"    timestamp(6),
     "create_time"    timestamp(6),
     "creator"        varchar(36) NULL,
     "creator"        varchar(36) NULL,

@@ -53,4 +53,10 @@ public class TkDbConnectDTO extends TenantDTO {
 
 
     @ApiModelProperty("最大等待时间(毫秒)")
     @ApiModelProperty("最大等待时间(毫秒)")
     private int connectTimeout;
     private int connectTimeout;
+
+    @ApiModelProperty("SSH通道配置信息")
+    private TkDbConnectSshDTO ssh;
+
+    @ApiModelProperty("SSL通道配置信息")
+    private TkDbConnectSslDTO ssl;
 }
 }

+package org.thingsboard.server.common.data.yunteng.dto;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * SSH通道配置信息
+ */
+@EqualsAndHashCode(callSuper = true)
+@Data
+public class TkDbConnectSshDTO extends TenantDTO {
+
+    @ApiModelProperty("数据库链接信息id")
+    private String connectId;
+
+    @ApiModelProperty("ssh的ip")
+    private String ip;
+
+    @ApiModelProperty("ssh的port")
+    private String port;
+
+    @ApiModelProperty("用户名")
+    private String sshName;
+
+    @ApiModelProperty("ssh的ip")
+    private String sshPassword;
+
+    @ApiModelProperty("验证方式（PASSWORD：密码；PUBLIC_KEY：公钥）")
+    private String verifyMethod;
+
+    @ApiModelProperty("私钥文件")
+    private String privateKey;
+}

+package org.thingsboard.server.common.data.yunteng.dto;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * SSL通道配置信息
+ */
+@EqualsAndHashCode(callSuper = true)
+@Data
+public class TkDbConnectSslDTO extends TenantDTO {
+
+    @ApiModelProperty("数据库链接信息id")
+    private String connectId;
+
+    @ApiModelProperty("CA证书")
+    private String caCert;
+
+    @ApiModelProperty("验证CA证书")
+    private boolean verifyCaCert;
+
+    @ApiModelProperty("客户端秘钥")
+    private String clientKey;
+
+    @ApiModelProperty("客户端证书")
+    private String clientCert;
+}

 /**
 /**
  * Copyright © 2016-2024 The Thingsboard Authors
  * Copyright © 2016-2024 The Thingsboard Authors
- *
+ * <p>
  * Licensed under the Apache License, Version 2.0 (the "License");
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
  * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
+ * <p>
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * <p>
  * Unless required by applicable law or agreed to in writing, software
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * See the License for the specific language governing permissions and
  * limitations under the License.
  * limitations under the License.
+ * <p>
+ * This file has been modified from its original version.
+ * Source: ThingsBoard Community Edition
+ * Modifications made by: Chengdu Yunteng Wuzhou Technology Co., Ltd
+ * Modification date: 2022-05-17
+ * Description of changes: extend constant for table.
  */
  */
 /**
 /**
  * This file has been modified from its original version.
  * This file has been modified from its original version.
@@ -45,7 +51,7 @@ public class ModelConstants {
      */
      */
     public static final String ID_PROPERTY = "id";
     public static final String ID_PROPERTY = "id";
     public static final String CREATED_TIME_PROPERTY = "created_time";
     public static final String CREATED_TIME_PROPERTY = "created_time";
-	//thingskit
+    //thingskit
     public static final String STATUS_PROPERTY = "status";
     public static final String STATUS_PROPERTY = "status";
     public static final String USER_ID_PROPERTY = "user_id";
     public static final String USER_ID_PROPERTY = "user_id";
     public static final String TENANT_ID_PROPERTY = "tenant_id";
     public static final String TENANT_ID_PROPERTY = "tenant_id";
@@ -71,7 +77,7 @@ public class ModelConstants {
     public static final String EVENT_TIME_COLUMN = "event_time";
     public static final String EVENT_TIME_COLUMN = "event_time";
     public static final String EVENT_TYPE_COLUMN = "event_type";
     public static final String EVENT_TYPE_COLUMN = "event_type";
     public static final String EVENT_VALUE_COLUMN = "event_value";
     public static final String EVENT_VALUE_COLUMN = "event_value";
-    public static final String  DATA_COMBINATION_IS_DEFAULT_PROPERTY= "is_data_combination";
+    public static final String DATA_COMBINATION_IS_DEFAULT_PROPERTY = "is_data_combination";
 
 
     /**
     /**
      * User constants.
      * User constants.
@@ -689,13 +695,15 @@ public class ModelConstants {
     public static final String TKINSTALLLOCATION_TABLE_NAME = "qg_install_location";//设备台账
     public static final String TKINSTALLLOCATION_TABLE_NAME = "qg_install_location";//设备台账
     public static final String TKSUPPLIER_TABLE_NAME = "qg_supplier";//供应商
     public static final String TKSUPPLIER_TABLE_NAME = "qg_supplier";//供应商
 
 
-    public static final String TKINSPECTIONPLAN_TABLE_NAME= "qg_inspection_plan"; // 巡检计划
-    public static final String TKCHECKPLAN_TABLE_NAME= "qg_check_plan"; // 巡检/保养方案
-    public static final String TKCHECKDETAILS_TABLE_NAME= "qg_check_details"; // 巡检明细
-    public static final String TKINSPECTIONRECORD_TABLE_NAME= "qg_inspection_record"; // 巡检记录
-    public static final String TKINSPECTIONDETAILS_TABLE_NAME= "qg_inspection_details"; // 巡检记录明细
+    public static final String TKINSPECTIONPLAN_TABLE_NAME = "qg_inspection_plan"; // 巡检计划
+    public static final String TKCHECKPLAN_TABLE_NAME = "qg_check_plan"; // 巡检/保养方案
+    public static final String TKCHECKDETAILS_TABLE_NAME = "qg_check_details"; // 巡检明细
+    public static final String TKINSPECTIONRECORD_TABLE_NAME = "qg_inspection_record"; // 巡检记录
+    public static final String TKINSPECTIONDETAILS_TABLE_NAME = "qg_inspection_details"; // 巡检记录明细
 
 
-    public static final String TKDBCONNECT_TABLE_NAME= "qg_db_connect"; // 数据库链接信息
+    public static final String TKDBCONNECT_TABLE_NAME = "qg_db_connect"; // 数据库链接信息
+    public static final String TKDBCONNECTSSH_TABLE_NAME = "qg_db_connect_ssh"; // SSH通道配置信息
+    public static final String TKDBCONNECTSSL_TABLE_NAME = "qg_db_connect_ssl"; // SSL通道配置信息
 
 
     protected static final String[] NONE_AGGREGATION_COLUMNS = new String[]{LONG_VALUE_COLUMN, DOUBLE_VALUE_COLUMN, BOOLEAN_VALUE_COLUMN, STRING_VALUE_COLUMN, JSON_VALUE_COLUMN, KEY_COLUMN, TS_COLUMN};
     protected static final String[] NONE_AGGREGATION_COLUMNS = new String[]{LONG_VALUE_COLUMN, DOUBLE_VALUE_COLUMN, BOOLEAN_VALUE_COLUMN, STRING_VALUE_COLUMN, JSON_VALUE_COLUMN, KEY_COLUMN, TS_COLUMN};
 
 

+package org.thingsboard.server.dao.yunteng.entities;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.thingsboard.server.dao.model.ModelConstants;
+
+/**
+ * SSH通道配置信息
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@TableName(value = ModelConstants.TKDBCONNECTSSH_TABLE_NAME, autoResultMap = true)
+public class TkDbConnectSshEntity extends TenantBaseEntity {
+
+    private String connectId;
+
+    private String ip;
+
+    private String port;
+
+    private String sshName;
+
+    private String sshPassword;
+
+    private String verifyMethod;
+
+    private String privateKey;
+
+}

+package org.thingsboard.server.dao.yunteng.entities;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.thingsboard.server.dao.model.ModelConstants;
+
+/**
+ * SSL通道配置信息
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@TableName(value = ModelConstants.TKDBCONNECTSSL_TABLE_NAME, autoResultMap = true)
+public class TkDbConnectSslEntity extends TenantBaseEntity {
+
+    private String connectId;
+
+    private String ip;
+
+    private String port;
+
+    private String sshName;
+
+    private String sshPassword;
+
+    private String verifyMethod;
+
+    private String privateKey;
+
+}

@@ -9,11 +9,15 @@ import org.apache.commons.lang3.StringUtils;
 import org.springframework.stereotype.Service;
 import org.springframework.stereotype.Service;
 import org.thingsboard.server.common.data.yunteng.core.exception.TkDataValidationException;
 import org.thingsboard.server.common.data.yunteng.core.exception.TkDataValidationException;
 import org.thingsboard.server.common.data.yunteng.dto.TkDbConnectDTO;
 import org.thingsboard.server.common.data.yunteng.dto.TkDbConnectDTO;
+import org.thingsboard.server.common.data.yunteng.dto.TkDbConnectSshDTO;
+import org.thingsboard.server.common.data.yunteng.dto.TkDbConnectSslDTO;
 import org.thingsboard.server.common.data.yunteng.utils.tools.TkPageData;
 import org.thingsboard.server.common.data.yunteng.utils.tools.TkPageData;
 import org.thingsboard.server.dao.yunteng.entities.TkDbConnectEntity;
 import org.thingsboard.server.dao.yunteng.entities.TkDbConnectEntity;
 import org.thingsboard.server.dao.yunteng.mapper.TkDbConnectMapper;
 import org.thingsboard.server.dao.yunteng.mapper.TkDbConnectMapper;
 import org.thingsboard.server.dao.yunteng.service.AbstractBaseService;
 import org.thingsboard.server.dao.yunteng.service.AbstractBaseService;
 import org.thingsboard.server.dao.yunteng.service.TkDbConnectService;
 import org.thingsboard.server.dao.yunteng.service.TkDbConnectService;
+import org.thingsboard.server.dao.yunteng.service.TkDbConnectSshService;
+import org.thingsboard.server.dao.yunteng.service.TkDbConnectSslService;
 
 
 import java.util.Map;
 import java.util.Map;
 
 
@@ -22,6 +26,8 @@ import java.util.Map;
 @Slf4j
 @Slf4j
 public class TkDbConnectServiceImpl extends AbstractBaseService<TkDbConnectMapper, TkDbConnectEntity>
 public class TkDbConnectServiceImpl extends AbstractBaseService<TkDbConnectMapper, TkDbConnectEntity>
         implements TkDbConnectService {
         implements TkDbConnectService {
+    private final TkDbConnectSshService tkDbConnectSshService;
+    private final TkDbConnectSslService tkDbConnectSslService;
 
 
     @Override
     @Override
     public TkPageData<TkDbConnectDTO> page(Map<String, Object> queryMap, String tenantId) {
     public TkPageData<TkDbConnectDTO> page(Map<String, Object> queryMap, String tenantId) {
@@ -55,7 +61,15 @@ public class TkDbConnectServiceImpl extends AbstractBaseService<TkDbConnectMappe
             entity = tkDbConnectDTO.getEntity(TkDbConnectEntity.class);
             entity = tkDbConnectDTO.getEntity(TkDbConnectEntity.class);
             baseMapper.update(entity, filter);
             baseMapper.update(entity, filter);
         }
         }
-
+        String connectId = entity.getId();
+        TkDbConnectSshDTO ssh = tkDbConnectDTO.getSsh();
+        ssh.setConnectId(connectId);
+        ssh.setTenantId(tkDbConnectDTO.getTenantId());
+        tkDbConnectSshService.save(ssh);
+        TkDbConnectSslDTO ssl = tkDbConnectDTO.getSsl();
+        ssl.setConnectId(connectId);
+        ssl.setTenantId(tkDbConnectDTO.getTenantId());
+        tkDbConnectSslService.save(ssl);
         entity.copyToDTO(tkDbConnectDTO);
         entity.copyToDTO(tkDbConnectDTO);
         return tkDbConnectDTO;
         return tkDbConnectDTO;
     }
     }
@@ -68,6 +82,8 @@ public class TkDbConnectServiceImpl extends AbstractBaseService<TkDbConnectMappe
 
 
     @Override
     @Override
     public boolean delete(String id) {
     public boolean delete(String id) {
+        tkDbConnectSshService.deleteByConnectId(id);
+        tkDbConnectSslService.deleteByConnectId(id);
         int count = baseMapper.deleteById(id);
         int count = baseMapper.deleteById(id);
         return count > 0;
         return count > 0;
     }
     }
@@ -81,6 +97,11 @@ public class TkDbConnectServiceImpl extends AbstractBaseService<TkDbConnectMappe
         TkDbConnectEntity entity = baseMapper.selectById(id);
         TkDbConnectEntity entity = baseMapper.selectById(id);
         TkDbConnectDTO tkDbConnectDTO = new TkDbConnectDTO();
         TkDbConnectDTO tkDbConnectDTO = new TkDbConnectDTO();
         entity.copyToDTO(tkDbConnectDTO);
         entity.copyToDTO(tkDbConnectDTO);
+
+        TkDbConnectSshDTO ssh = tkDbConnectSshService.getByConnectId(id);
+        TkDbConnectSslDTO ssl = tkDbConnectSslService.getByConnectId(id);
+        tkDbConnectDTO.setSsh(ssh);
+        tkDbConnectDTO.setSsl(ssl);
         return tkDbConnectDTO;
         return tkDbConnectDTO;
     }
     }
 }
 }

+package org.thingsboard.server.dao.yunteng.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.stereotype.Service;
+import org.thingsboard.server.common.data.yunteng.core.exception.TkDataValidationException;
+import org.thingsboard.server.common.data.yunteng.dto.TkDbConnectSshDTO;
+import org.thingsboard.server.dao.yunteng.entities.TkDbConnectSshEntity;
+import org.thingsboard.server.dao.yunteng.mapper.TkDbConnectSshMapper;
+import org.thingsboard.server.dao.yunteng.service.AbstractBaseService;
+import org.thingsboard.server.dao.yunteng.service.TkDbConnectSshService;
+
+@Service
+@RequiredArgsConstructor
+@Slf4j
+public class TkDbConnectSshServiceImpl extends AbstractBaseService<TkDbConnectSshMapper, TkDbConnectSshEntity>
+        implements TkDbConnectSshService {
+
+    @Override
+    public TkDbConnectSshDTO save(TkDbConnectSshDTO tkDbConnectSshDTO) {
+        checkDto(tkDbConnectSshDTO);
+        TkDbConnectSshEntity entity = new TkDbConnectSshEntity();
+        if (StringUtils.isBlank(tkDbConnectSshDTO.getId())) {
+            tkDbConnectSshDTO.copyToEntity(entity);
+            baseMapper.insert(entity);
+        } else {
+            LambdaQueryWrapper<TkDbConnectSshEntity> filter = new QueryWrapper<TkDbConnectSshEntity>().lambda()
+                    .eq(TkDbConnectSshEntity::getId, tkDbConnectSshDTO.getId());
+            entity = tkDbConnectSshDTO.getEntity(TkDbConnectSshEntity.class);
+            baseMapper.update(entity, filter);
+        }
+
+        entity.copyToDTO(tkDbConnectSshDTO);
+        return tkDbConnectSshDTO;
+    }
+
+    @Override
+    public void deleteByConnectId(String connectId) {
+        if (StringUtils.isBlank(connectId)) {
+            return;
+        }
+
+        baseMapper.delete(new LambdaQueryWrapper<TkDbConnectSshEntity>().eq(TkDbConnectSshEntity::getConnectId, connectId));
+    }
+
+    @Override
+    public TkDbConnectSshDTO getByConnectId(String connectId) {
+        if (StringUtils.isBlank(connectId)) {
+            return new TkDbConnectSshDTO();
+        }
+
+        TkDbConnectSshEntity entity = baseMapper.selectOne(new LambdaQueryWrapper<TkDbConnectSshEntity>().eq(TkDbConnectSshEntity::getConnectId, connectId));
+        if (entity == null) {
+            return new TkDbConnectSshDTO();
+        }
+
+        TkDbConnectSshDTO dto = new TkDbConnectSshDTO();
+        entity.copyToDTO(dto);
+        return dto;
+    }
+
+    private void checkDto(TkDbConnectSshDTO dto) {
+        if (StringUtils.isBlank(dto.getTenantId())) {
+            throw new TkDataValidationException("租户id为空！");
+        }
+    }
+
+}

+package org.thingsboard.server.dao.yunteng.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.stereotype.Service;
+import org.thingsboard.server.common.data.yunteng.core.exception.TkDataValidationException;
+import org.thingsboard.server.common.data.yunteng.dto.TkDbConnectSslDTO;
+import org.thingsboard.server.dao.yunteng.entities.TkDbConnectSslEntity;
+import org.thingsboard.server.dao.yunteng.mapper.TkDbConnectSslMapper;
+import org.thingsboard.server.dao.yunteng.service.AbstractBaseService;
+import org.thingsboard.server.dao.yunteng.service.TkDbConnectSslService;
+
+@Service
+@RequiredArgsConstructor
+@Slf4j
+public class TkDbConnectSslServiceImpl extends AbstractBaseService<TkDbConnectSslMapper, TkDbConnectSslEntity>
+        implements TkDbConnectSslService {
+
+    @Override
+    public TkDbConnectSslDTO save(TkDbConnectSslDTO tkDbConnectSslDTO) {
+        checkDto(tkDbConnectSslDTO);
+        TkDbConnectSslEntity entity = new TkDbConnectSslEntity();
+        if (StringUtils.isBlank(tkDbConnectSslDTO.getId())) {
+            tkDbConnectSslDTO.copyToEntity(entity);
+            baseMapper.insert(entity);
+        } else {
+            LambdaQueryWrapper<TkDbConnectSslEntity> filter = new QueryWrapper<TkDbConnectSslEntity>().lambda()
+                    .eq(TkDbConnectSslEntity::getId, tkDbConnectSslDTO.getId());
+            entity = tkDbConnectSslDTO.getEntity(TkDbConnectSslEntity.class);
+            baseMapper.update(entity, filter);
+        }
+
+        entity.copyToDTO(tkDbConnectSslDTO);
+        return tkDbConnectSslDTO;
+    }
+
+    @Override
+    public void deleteByConnectId(String connectId) {
+        if (StringUtils.isBlank(connectId)) {
+            return;
+        }
+
+        baseMapper.delete(new LambdaQueryWrapper<TkDbConnectSslEntity>().eq(TkDbConnectSslEntity::getConnectId, connectId));
+    }
+
+    @Override
+    public TkDbConnectSslDTO getByConnectId(String connectId) {
+        if (StringUtils.isBlank(connectId)) {
+            return new TkDbConnectSslDTO();
+        }
+
+        TkDbConnectSslEntity entity = baseMapper.selectOne(new LambdaQueryWrapper<TkDbConnectSslEntity>().eq(TkDbConnectSslEntity::getConnectId, connectId));
+        if (entity == null) {
+            return new TkDbConnectSslDTO();
+        }
+
+        TkDbConnectSslDTO dto = new TkDbConnectSslDTO();
+        entity.copyToDTO(dto);
+        return dto;
+    }
+
+    private void checkDto(TkDbConnectSslDTO dto) {
+        if (StringUtils.isBlank(dto.getTenantId())) {
+            throw new TkDataValidationException("租户id为空！");
+        }
+    }
+}

+package org.thingsboard.server.dao.yunteng.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+import org.thingsboard.server.dao.yunteng.entities.TkDbConnectSshEntity;
+
+@Mapper
+public interface TkDbConnectSshMapper extends BaseMapper<TkDbConnectSshEntity> {
+}

+package org.thingsboard.server.dao.yunteng.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+import org.thingsboard.server.dao.yunteng.entities.TkDbConnectSslEntity;
+
+@Mapper
+public interface TkDbConnectSslMapper extends BaseMapper<TkDbConnectSslEntity> {
+}

+package org.thingsboard.server.dao.yunteng.service;
+
+import org.thingsboard.server.common.data.yunteng.dto.TkDbConnectSshDTO;
+import org.thingsboard.server.dao.yunteng.entities.TkDbConnectSshEntity;
+
+public interface TkDbConnectSshService extends BaseService<TkDbConnectSshEntity> {
+
+    TkDbConnectSshDTO save(TkDbConnectSshDTO tkDbConnectSshDTO);
+
+    void deleteByConnectId(String connectId);
+
+    TkDbConnectSshDTO getByConnectId(String connectId);
+}

+package org.thingsboard.server.dao.yunteng.service;
+
+import org.thingsboard.server.common.data.yunteng.dto.TkDbConnectSslDTO;
+import org.thingsboard.server.dao.yunteng.entities.TkDbConnectSslEntity;
+
+public interface TkDbConnectSslService extends BaseService<TkDbConnectSslEntity> {
+
+    TkDbConnectSslDTO save(TkDbConnectSslDTO tkDbConnectSslDTO);
+
+    void deleteByConnectId(String connectId);
+
+    TkDbConnectSslDTO getByConnectId(String connectId);
+}