feat: add frp remote manager

+package org.thingsboard.server.controller.yunteng;
+
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.RequiredArgsConstructor;
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.web.bind.annotation.*;
+import org.thingsboard.server.common.data.exception.ThingsboardException;
+import org.thingsboard.server.common.data.yunteng.dto.FrpInfoDTO;
+import org.thingsboard.server.dao.yunteng.service.YtFrpInfoService;
+
+@RestController
+@RequestMapping("api/yt/frp")
+@Api(tags = "Frp内网穿透信息")
+@RequiredArgsConstructor
+@PreAuthorize("hasAnyAuthority('TENANT_ADMIN','CUSTOMER_USER')")
+public class YtFrpInfoController {
+
+  private final YtFrpInfoService frpInfoService;
+
+  @GetMapping("/{proxyName}")
+  @ApiOperation("通过代理名称或SN获取内网穿透信息")
+  public FrpInfoDTO findFrpInfoByProxyName(@PathVariable("proxyName") String proxyName)
+      throws ThingsboardException {
+    return frpInfoService.findFrpInfoByProxyName(proxyName);
+  }
+
+  @PutMapping("/{proxyName}/{enableRemote}")
+  @ApiOperation("是否开启远程连接：0关闭 1开启")
+  public FrpInfoDTO updateFrpInfoByProxyName(
+      @PathVariable("proxyName") String proxyName,
+      @PathVariable("enableRemote") Integer enableRemote)
+      throws ThingsboardException {
+    FrpInfoDTO frpInfoDTO = frpInfoService.findFrpInfoByProxyName(proxyName);
+    frpInfoDTO.setEnableRemote(enableRemote);
+    return frpInfoService.saveOrUpdateFrpInfo(frpInfoDTO);
+  }
+}

 package org.thingsboard.server.controller.yunteng;
 
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.node.ObjectNode;
 import io.swagger.annotations.ApiOperation;
 import lombok.RequiredArgsConstructor;
 import org.springframework.util.Assert;
 import org.springframework.web.bind.annotation.*;
 import org.thingsboard.server.common.data.exception.ThingsboardException;
+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.FrpInfoDTO;
 import org.thingsboard.server.common.data.yunteng.dto.request.AccountReqDTO;
-import org.thingsboard.server.common.data.yunteng.dto.request.SendResetPasswordEmailMsg;
+import org.thingsboard.server.common.data.yunteng.enums.FrpPluginsEnum;
 import org.thingsboard.server.common.data.yunteng.enums.MsgTemplatePurposeEnum;
+import org.thingsboard.server.common.data.yunteng.enums.StatusEnum;
+import org.thingsboard.server.common.data.yunteng.utils.JacksonUtil;
+import org.thingsboard.server.controller.BaseController;
+import org.thingsboard.server.dao.yunteng.service.YtFrpInfoService;
 import org.thingsboard.server.dao.yunteng.service.YtSmsService;
 import org.thingsboard.server.dao.yunteng.service.YtUserService;
 
+import java.net.UnknownHostException;
+import java.util.Optional;
+
 import static org.thingsboard.server.common.data.yunteng.constant.FastIotConstants.CHINA_MOBILE_PATTERN;
 
 @RestController
 @RequestMapping("api/yt/noauth")
 @RequiredArgsConstructor
-public class YtNoAuthController {
+public class YtNoAuthController extends BaseController {
 
   private final YtSmsService smsService;
   private final YtUserService userService;
+  private final YtFrpInfoService frpInfoService;
 
   @PostMapping("/sendLoginSmsCode/{phoneNumber}")
   public boolean sendVerificationCode(@PathVariable("phoneNumber") String phoneNumber) {
@@ -30,8 +43,10 @@ public class YtNoAuthController {
 
   @PostMapping("/reset/{phoneNumber}")
   @ApiOperation("密码找回")
-  public void saveForgetPassword(@PathVariable("phoneNumber") String phoneNumber,@RequestBody AccountReqDTO forget) throws ThingsboardException {
-    userService.forgetPassword(phoneNumber,forget);
+  public void saveForgetPassword(
+      @PathVariable("phoneNumber") String phoneNumber, @RequestBody AccountReqDTO forget)
+      throws ThingsboardException {
+    userService.forgetPassword(phoneNumber, forget);
   }
 
   @PostMapping("/resetCode/{phoneNumber}")
@@ -39,4 +54,57 @@ public class YtNoAuthController {
   public void forgetPasswordCode(@PathVariable("phoneNumber") String phoneNumber) {
     smsService.sendSmsCode(phoneNumber, MsgTemplatePurposeEnum.FOR_FORGET_PASSWORD);
   }
+
+  @PostMapping("/handler")
+  @ApiOperation("操作Frp内网穿透信息")
+  public JsonNode forgetPasswordCode(@RequestBody ObjectNode params)
+      throws ThingsboardException, UnknownHostException {
+    String value =
+        Optional.ofNullable(params)
+            .map(param -> params.get("op").asText())
+            .orElseThrow(
+                () -> new YtDataValidationException(ErrorMessage.INVALID_PARAMETER.getMessage()));
+    ObjectNode objectNode = JacksonUtil.newObjectNode();
+    ObjectNode content =
+        Optional.ofNullable(params.get("content"))
+            .map(data -> JacksonUtil.convertValue(params.get("content"), ObjectNode.class))
+            .orElseThrow(
+                () -> new YtDataValidationException(ErrorMessage.INVALID_PARAMETER.getMessage()));
+    String sn = null;
+    FrpInfoDTO queryFrpInfoDTO = null;
+    if (!value.equals(FrpPluginsEnum.Login.name()) && !value.equals(FrpPluginsEnum.Ping.name())) {
+      sn =
+          Optional.ofNullable(content.get("proxy_name"))
+              .map(proxyName -> content.get("proxy_name").asText())
+              .orElseThrow(
+                  () -> new YtDataValidationException(ErrorMessage.INVALID_PARAMETER.getMessage()));
+      queryFrpInfoDTO = frpInfoService.findFrpInfoByProxyName(sn);
+    }
+
+    if (value.equals(FrpPluginsEnum.NewProxy.name())) {
+      // 创建新代理,保存客户端数据到数据库,如已存在数据则更新数据即可,设置连接状态为在线
+      frpInfoService.saveOrUpdateContent(content, queryFrpInfoDTO, sn);
+    }
+    if (value.equals(FrpPluginsEnum.CloseProxy.name())) {
+      // 关闭代理,设置连接状态为离线
+      if (null != queryFrpInfoDTO) {
+        queryFrpInfoDTO.setStatus(StatusEnum.OFFLINE.getIndex());
+        frpInfoService.saveOrUpdateFrpInfo(queryFrpInfoDTO);
+      }
+    }
+    if (value.equals(FrpPluginsEnum.NewUserConn.name())) {
+      // 如果平台允许远程连接为开,则允许连接。否则拒绝执行操作
+      if (null == queryFrpInfoDTO || queryFrpInfoDTO.getEnableRemote() == 0) {
+        objectNode.put("reject", true);
+        objectNode.put("reject_reason", "invalid user");
+        return objectNode;
+      }
+    }
+    /** 第一种 拒绝执行操作 { "reject": true, "reject_reason": "invalid user" } */
+    /** 第二种 允许且内容不需要变动 { "reject": false, "unchange": true } */
+    /** 第三种 允许且需要替换操作内容 { "unchange": "false", "content": { ... // 替换后的操作信息，格式必须和请求时的一致 } } */
+    objectNode.put("reject", false);
+    objectNode.put("unchange", true);
+    return objectNode;
+  }
 }

@@ -87,6 +87,8 @@ public final class ModelConstants {
     public static final String IOTFS_OPINION_TABLE_NAME = "iotfs_opinion";
     /** 第三方用户表 */
     public static final String IOTFS_THIRD_USER_TABLE_NAME = "iotfs_third_user";
+    /** frp内网穿透信息表 */
+    public static final String IOTFS_FRP_INFO_NAME = "iotfs_frp_info";
   }
 
   public static class TableFields {

@@ -68,6 +68,7 @@ public enum ErrorMessage {
   VIDEO_PLATFORM_CONFIG_ERROR(400048,"流媒体平台信息配置有误"),
   VIDEO_PLATFORM_NEED_ENABLE_HLS_HTTPS(400049,"平台需开启https的hls协议"),
   NAME_EXISTED(400050,"名称【%s】已存在"),
+  INVALID_PARAMETER_OR_NOT_MATCH_TENANT(400051,"参数错误或该条数据不属于当前租户"),
   HAVE_NO_PERMISSION(500002,"没有修改权限");
   private final int code;
   private String message;

+package org.thingsboard.server.common.data.yunteng.dto;
+
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+@EqualsAndHashCode(callSuper = false)
+@Data
+public class FrpInfoDTO extends BaseDTO {
+
+  /** 访问地址 */
+  private String address;
+
+  /** 代理名称或设备SN */
+  private String proxyName;
+
+  /** 端口 */
+  private Integer remotePort;
+
+  /** 客户端FRP运行ID */
+  private String runId;
+
+  /** 状态：0离线 1在线 */
+  private Integer status;
+
+  /** 允许远程 */
+  private Integer enableRemote;
+
+  /** 备注 */
+  private String remark;
+}

+package org.thingsboard.server.common.data.yunteng.enums;
+
+public enum FrpPluginsEnum {
+    /**
+     * FRP心跳
+     */
+    Ping,
+    /**
+     * FRP登录
+     */
+    Login,
+    /**
+     * FRP创建代理
+     */
+    NewProxy,
+    /**
+     * FRP关闭代理
+     */
+    CloseProxy,
+    /**
+     * FRP创建新的工作连接
+     */
+    NewWorkConn,
+    /**
+     * FRP创建新的用户连接
+     */
+    NewUserConn
+
+}

+package org.thingsboard.server.common.data.yunteng.enums;
+
+import lombok.Getter;
+import lombok.Setter;
+
+public enum StatusEnum {
+    OFFLINE("离线",0),
+    ONLINE("在线",1);
+
+    @Getter
+    @Setter
+    private String name;
+    @Getter
+    @Setter
+    private Integer index;
+
+    StatusEnum(String name, Integer index) {
+        this.name = name;
+        this.index = index;
+    }
+
+}

+package org.thingsboard.server.dao.yunteng.entities;
+
+import com.baomidou.mybatisplus.annotation.*;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.thingsboard.server.common.data.yunteng.constant.ModelConstants;
+
+import java.time.LocalDateTime;
+
+@Data
+@EqualsAndHashCode(callSuper = true)
+@TableName(value = ModelConstants.Table.IOTFS_FRP_INFO_NAME, autoResultMap = true)
+public class FrpInfo extends BaseEntity {
+
+  private static final long serialVersionUID = 970621268444886639L;
+
+  @TableField(fill = FieldFill.INSERT)
+  private LocalDateTime createTime;
+
+  @TableField(fill = FieldFill.UPDATE)
+  private LocalDateTime updateTime;
+
+  /**
+   * 访问地址
+   */
+  private String address;
+
+  /** 代理名称或设备SN */
+  private String proxyName;
+
+  /** 端口 */
+  private Integer remotePort;
+
+  /** 客户端FRP运行ID */
+  private String runId;
+
+  /** 状态：0离线 1在线 */
+  private Integer status;
+
+  /** 允许远程 */
+  private Integer enableRemote;
+
+  /** 备注 */
+  private String remark;
+}

+package org.thingsboard.server.dao.yunteng.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.fasterxml.jackson.databind.node.ObjectNode;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.stereotype.Service;
+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.FrpInfoDTO;
+import org.thingsboard.server.common.data.yunteng.enums.StatusEnum;
+import org.thingsboard.server.common.data.yunteng.utils.tools.YtPageData;
+import org.thingsboard.server.dao.yunteng.entities.FrpInfo;
+import org.thingsboard.server.dao.yunteng.mapper.FrpInfoMapper;
+import org.thingsboard.server.dao.yunteng.service.AbstractBaseService;
+import org.thingsboard.server.dao.yunteng.service.YtFrpInfoService;
+
+import java.net.InetAddress;
+import java.net.UnknownHostException;
+import java.time.LocalDateTime;
+import java.util.Map;
+import java.util.Optional;
+
+@Service
+public class YtFrpInfoServiceImpl extends AbstractBaseService<FrpInfoMapper, FrpInfo>
+    implements YtFrpInfoService {
+  @Override
+  public YtPageData<FrpInfoDTO> page(Map<String, Object> queryMap) {
+    String proxyName =
+        queryMap.get("proxyName") != null ? queryMap.get("proxyName").toString() : null;
+    IPage<FrpInfo> frpInfoIPage =
+        baseMapper.selectPage(
+            getPage(queryMap, "create_time", false),
+            new LambdaQueryWrapper<FrpInfo>()
+                .eq(StringUtils.isNotEmpty(proxyName), FrpInfo::getProxyName, proxyName));
+    return getPageData(frpInfoIPage, FrpInfoDTO.class);
+  }
+
+  @Override
+  public FrpInfoDTO saveOrUpdateFrpInfo(FrpInfoDTO frpInfoDTO) {
+    if (null == frpInfoDTO) {
+      throw new YtDataValidationException(ErrorMessage.INVALID_PARAMETER.getMessage());
+    }
+    if (StringUtils.isEmpty(frpInfoDTO.getId())) {
+      frpInfoDTO.setCreateTime(LocalDateTime.now());
+      baseMapper.insert(frpInfoDTO.getEntity(FrpInfo.class));
+    } else {
+      FrpInfo frpInfo =
+          baseMapper.selectOne(
+              new LambdaQueryWrapper<FrpInfo>().eq(FrpInfo::getId, frpInfoDTO.getId()));
+      frpInfoDTO.setUpdateTime(LocalDateTime.now());
+      Optional.ofNullable(frpInfo)
+          .map(info -> baseMapper.updateById(frpInfoDTO.getEntity(FrpInfo.class)))
+          .orElseThrow(
+              () ->
+                  new YtDataValidationException(
+                      ErrorMessage.INVALID_PARAMETER_OR_NOT_MATCH_TENANT.getMessage()));
+    }
+    return frpInfoDTO;
+  }
+
+  @Override
+  public boolean deleteFrpInfo(DeleteDTO deleteDTO) {
+    if (deleteDTO.getIds().isEmpty()) {
+      throw new YtDataValidationException(ErrorMessage.INVALID_PARAMETER.getMessage());
+    }
+    return baseMapper.deleteBatchIds(deleteDTO.getIds()) > 0;
+  }
+
+  @Override
+  public FrpInfoDTO findFrpInfoById(String id) {
+    if (StringUtils.isEmpty(id)) {
+      throw new YtDataValidationException(ErrorMessage.INVALID_PARAMETER.getMessage());
+    }
+    FrpInfo frpInfo =
+        baseMapper.selectOne(new LambdaQueryWrapper<FrpInfo>().eq(FrpInfo::getId, id));
+    return Optional.ofNullable(frpInfo)
+        .map(info -> frpInfo.getDTO(FrpInfoDTO.class))
+        .orElseThrow(
+            () ->
+                new YtDataValidationException(
+                    ErrorMessage.INVALID_PARAMETER_OR_NOT_MATCH_TENANT.getMessage()));
+  }
+
+  @Override
+  public FrpInfoDTO findFrpInfoByProxyName(String proxyName) {
+    if (StringUtils.isEmpty(proxyName)) {
+      throw new YtDataValidationException(ErrorMessage.INVALID_PARAMETER.getMessage());
+    }
+    FrpInfo frpInfo =
+        baseMapper.selectOne(
+            new LambdaQueryWrapper<FrpInfo>().eq(StringUtils.isNotEmpty(proxyName),FrpInfo::getProxyName, proxyName));
+    return Optional.ofNullable(frpInfo).map(info -> frpInfo.getDTO(FrpInfoDTO.class)).orElse(null);
+  }
+
+  @Override
+  public FrpInfoDTO saveOrUpdateContent(ObjectNode content, FrpInfoDTO queryFrpInfoDTO, String sn)
+      throws UnknownHostException {
+    String runId =
+        Optional.ofNullable(content.get("user"))
+            .map(user -> content.get("user").get("run_id").asText())
+            .orElseThrow(
+                () -> new YtDataValidationException(ErrorMessage.INVALID_PARAMETER.getMessage()));
+    Integer remotePort =
+        Optional.ofNullable(content.get("remote_port"))
+            .map(remote -> content.get("remote_port").asInt())
+            .orElseThrow(
+                () -> new YtDataValidationException(ErrorMessage.INVALID_PARAMETER.getMessage()));
+
+    FrpInfoDTO saveFrpInfoDTO = new FrpInfoDTO();
+    if (null == queryFrpInfoDTO) {
+      saveFrpInfoDTO.setProxyName(sn);
+      saveFrpInfoDTO.setRemotePort(remotePort);
+      saveFrpInfoDTO.setRunId(runId);
+      saveFrpInfoDTO.setStatus(StatusEnum.ONLINE.getIndex());
+    } else {
+      queryFrpInfoDTO.setRunId(runId);
+      queryFrpInfoDTO.setStatus(StatusEnum.ONLINE.getIndex());
+      saveFrpInfoDTO = queryFrpInfoDTO;
+    }
+    saveFrpInfoDTO.setAddress(
+        "http://" + InetAddress.getLocalHost().getHostAddress() + ":" + remotePort);
+    return saveOrUpdateFrpInfo(saveFrpInfoDTO);
+  }
+}

+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.FrpInfo;
+
+@Mapper
+public interface FrpInfoMapper extends BaseMapper<FrpInfo> {
+
+}

+package org.thingsboard.server.dao.yunteng.service;
+
+import com.fasterxml.jackson.databind.node.ObjectNode;
+import org.thingsboard.server.common.data.yunteng.dto.DeleteDTO;
+import org.thingsboard.server.common.data.yunteng.dto.FrpInfoDTO;
+import org.thingsboard.server.common.data.yunteng.utils.tools.YtPageData;
+
+import java.net.UnknownHostException;
+import java.util.Map;
+
+public interface YtFrpInfoService {
+
+  YtPageData<FrpInfoDTO> page(Map<String, Object> queryMap);
+
+  FrpInfoDTO saveOrUpdateFrpInfo(FrpInfoDTO frpInfoDTO);
+
+  boolean deleteFrpInfo(DeleteDTO deleteDTO);
+
+  FrpInfoDTO findFrpInfoById(String id);
+
+  FrpInfoDTO findFrpInfoByProxyName(String proxyName);
+
+  FrpInfoDTO saveOrUpdateContent(ObjectNode content, FrpInfoDTO queryFrpInfoDTO, String sn)
+      throws UnknownHostException;
+}