数据补发测试接口

2024年9月27日10:05:52

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<>();
+    }
+
 
 }

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);
+
 
 }

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();