From 786524cbf9c16a8496c214c0494ffd2e3e177441 Mon Sep 17 00:00:00 2001
From: lishuai <lishuai@qq.com>
Date: Fri, 27 Sep 2024 10:05:57 +0800
Subject: [PATCH] =?UTF-8?q?=E6=95=B0=E6=8D=AE=E8=A1=A5=E5=8F=91=E6=B5=8B?=
 =?UTF-8?q?=E8=AF=95=E6=8E=A5=E5=8F=A3=202024=E5=B9=B49=E6=9C=8827?=
 =?UTF-8?q?=E6=97=A510:05:52?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../reissue/controller/DataReissueController.java  |  7 +++++++
 .../thing/reissue/service/DataReissueService.java  |  3 ++-
 .../service/impl/DataReissueServiceImpl.java       | 14 +++++++++++++-
 3 files changed, 22 insertions(+), 2 deletions(-)

diff --git a/modules/thing/src/main/java/com/thing/reissue/controller/DataReissueController.java b/modules/thing/src/main/java/com/thing/reissue/controller/DataReissueController.java
index 528bf36..e5d53c1 100644
--- a/modules/thing/src/main/java/com/thing/reissue/controller/DataReissueController.java
+++ b/modules/thing/src/main/java/com/thing/reissue/controller/DataReissueController.java
@@ -33,5 +33,12 @@ public class DataReissueController {
         return new Result<List<SysTenantDTO>>().ok(dtos);
     }
 
+    @GetMapping("test")
+    @Operation(summary="测试")
+    public Result<Void> testConnect(@RequestParam String username, @RequestParam String password, @RequestParam String url){
+        dataReissueService.testConnect(username, password, url);
+        return new Result<>();
+    }
+
 
 }
\ No newline at end of file
diff --git a/modules/thing/src/main/java/com/thing/reissue/service/DataReissueService.java b/modules/thing/src/main/java/com/thing/reissue/service/DataReissueService.java
index 9a9afa1..e3da98d 100644
--- a/modules/thing/src/main/java/com/thing/reissue/service/DataReissueService.java
+++ b/modules/thing/src/main/java/com/thing/reissue/service/DataReissueService.java
@@ -18,8 +18,9 @@ public interface DataReissueService extends IBaseService<DataReissueEntity> {
 
     void dataReissue(DataReissueDTO dataReissue);
 
-
     List<SysTenantDTO> tenantList();
 
+    void testConnect(String username, String password,String url);
+
 
 }
\ No newline at end of file
diff --git a/modules/thing/src/main/java/com/thing/reissue/service/impl/DataReissueServiceImpl.java b/modules/thing/src/main/java/com/thing/reissue/service/impl/DataReissueServiceImpl.java
index 41d4a67..c2f1151 100644
--- a/modules/thing/src/main/java/com/thing/reissue/service/impl/DataReissueServiceImpl.java
+++ b/modules/thing/src/main/java/com/thing/reissue/service/impl/DataReissueServiceImpl.java
@@ -35,12 +35,12 @@ import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.core.ParameterizedTypeReference;
 import org.springframework.http.*;
 import org.springframework.stereotype.Service;
+import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.client.RestTemplate;
 import org.springframework.web.util.UriComponents;
 import org.springframework.web.util.UriComponentsBuilder;
 import org.thingsboard.server.common.data.Device;
 import org.thingsboard.server.common.data.id.DeviceId;
-import org.thingsboard.server.common.data.kv.*;
 
 import java.util.*;
 import java.util.stream.Collectors;
@@ -223,6 +223,18 @@ public class DataReissueServiceImpl extends BaseServiceImpl<DataReissueMapper, D
         return sysTenantDao.queryList(params).parallelStream().sorted(Comparator.comparingLong(SysTenantDTO::getTenantCode)).collect(Collectors.toList());
     }
 
+    @Override
+    public void testConnect(String username, String password,String url) {
+        try {
+            String token = login(url, username, password);
+            if (StringUtils.isBlank(token)) {
+                throw new SysException("连接失败");
+            }
+        }catch (Exception e){
+            throw new SysException("连接失败");
+        }
+    }
+
 
     private String login(String url, String username, String password) {
         Map<String, String> loginRequest = new HashMap();