fix:适配exa接口-获取组名字段变化

yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/controller/admin/exa/EXAController.java

@@ -89,8 +89,8 @@ public class EXAController {
     @GetMapping("/group")
     @Operation(summary = "获取EXA所有组名")
     @PreAuthorize("@ss.hasPermission('alert:exa:query')")
-    public CommonResult<List<Object>> getEXAGroupInfo() throws URISyntaxException, IOException {
+    public CommonResult<List<List<String>>> getEXAGroupInfo() throws URISyntaxException, IOException {
-        List<Object> groupList=exaService.getEXAGroupInfo();
+        List<List<String>> groupList=exaService.getEXAGroupInfo();
         return success(groupList);
     }
 
@@ -132,7 +132,7 @@ public class EXAController {
     @PreAuthorize("@ss.hasPermission('system:user:import')")
     public CommonResult<EXAPointImportRespVO> importExcel(@RequestParam("file") MultipartFile file,
                                                           @RequestParam(value = "updateSupport", required = false, defaultValue = "false") Boolean updateSupport) throws Exception {
-        System.out.println(file);
+        System.out.println(file.getInputStream());
         List<Point> list = ExcelUtils.readCSV(file, Point.class);
         return success(exaService.importPointList(list, updateSupport));
     }

yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/controller/admin/exa/vo/EXAGroupRespVO.java

@@ -0,0 +1,26 @@
+package cn.iocoder.yudao.module.alert.controller.admin.exa.vo;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Schema(description = "EXA - 获取组名 Response VO")
+@Data
+@NoArgsConstructor  // 添加无参构造器
+@AllArgsConstructor // 添加全参构造器，与@Builder兼容
+public class EXAGroupRespVO {
+        /**
+         * 组名
+         */
+        @JSONField(name="GroupsJson")
+        private String GroupsJson;
+
+        /**
+         * 返回值
+         */
+        @JSONField(name="ReturnValue")
+        private Long ReturnValue;
+}

yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/controller/admin/exa/vo/EXAResult.java

@@ -1,7 +1,9 @@
 package cn.iocoder.yudao.module.alert.controller.admin.exa.vo;
 
 import com.alibaba.fastjson.annotation.JSONField;
+import lombok.Data;
 
+@Data
 public class EXAResult {
     @JSONField(name="ReturnValue")
     public Long ReturnValue;

yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/controller/admin/exa/vo/Point.java

@@ -15,8 +15,8 @@ import lombok.experimental.Accessors;
 @NoArgsConstructor
 @Accessors(chain = false) // 设置 chain = false，避免用户导入有问题
 public class Point {
-    @Schema(description = "", example = "芋道")
+//    @Schema(description = "", example = "芋道")
-    public String AssetCode;
+//    public String AssetCode;
     
     @ExcelProperty("点号名称")
     @Schema(description = "点号", example = "芋道")

yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/service/exa/EXAService.java

@@ -34,7 +34,7 @@ public interface EXAService {
 
     String createPoint(Point pointVo) throws IOException;
 
-    public  List<Object> getEXAGroupInfo() throws URISyntaxException, IOException;
+    public  List<List<String>> getEXAGroupInfo() throws URISyntaxException, IOException;
 
     public  String deletePoint(String ItemName);
     EXAPointImportRespVO importPointList(List<Point> importPoints, boolean isUpdateSupport);

yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/service/exa/EXAServiceImpl.java

@@ -6,6 +6,7 @@ import cn.iocoder.yudao.module.alert.controller.admin.exa.vo.*;
 
 import cn.iocoder.yudao.module.alert.controller.admin.system.vo.PointOptionItemVO;
 import cn.iocoder.yudao.module.alert.utils.EXAUtils;
+import com.alibaba.fastjson.JSON;
 import lombok.extern.slf4j.Slf4j;
 
 import org.springframework.beans.factory.annotation.Value;
@@ -129,7 +130,7 @@ public class EXAServiceImpl implements EXAService {
      * @return 分页结果
      */
     @Override
-    public  List<Object> getEXAGroupInfo() throws URISyntaxException, IOException {
+    public  List<List<String>> getEXAGroupInfo() throws URISyntaxException, IOException {
         return exaUtils.getGroup(EXA_IP);
     }
     /**
@@ -164,7 +165,9 @@ public class EXAServiceImpl implements EXAService {
         importPoints.forEach(importUser -> {
             try {
                 String createResult=createPoint(importUser);
-                if(createResult.equals("1")){
+                EXAResult vo = JSON.parseObject(createResult, EXAResult.class);
+
+                if(vo.ReturnValue.equals(1L)){
                     respVO.getCreateNames().add(importUser.getItemName());
                 }
 

yudao-module-alert/yudao-module-alert-biz/src/main/java/cn/iocoder/yudao/module/alert/utils/EXAUtils.java

@@ -276,53 +276,85 @@ public class EXAUtils {
         return result;
     }
 
-    public List<Object> getGroup(String EXA_IP) throws URISyntaxException, IOException {
-        List<Object> result = new ArrayList<>();
-        try {
-            // 目标 RPC 服务的 URL
-            String url = "http://" + EXA_IP + ":9000/exawebapi/exagroup/getgroups";
-            //创建HttpClient对象
-            CloseableHttpClient httpClient = HttpClients.createDefault();
-            /*
-             * 由于GET请求的参数都是拼装在URL地址后方，所以我们要构建一个URL，带参数
-             */
-            URIBuilder uriBuilder = new URIBuilder(url);
-
-            /** 添加参数 */
-//            uriBuilder.addParameter("ItemNames", itemNames);
 
-            //创建请求对象
+    public List<List<String>> getGroup(String EXA_IP) throws IOException {
-            HttpGet httpGet = new HttpGet(uriBuilder.build());
+        String requestPathAddItem = "http://" + EXA_IP + ":9000/exawebapi/EXAItem/GetAllGroups";
+        String result = Request.Post(requestPathAddItem)
+                .addHeader("Content-type", "application/json")
+                .execute().returnContent().asString(Charset.forName("utf-8"));
+        // Add validation for empty or null response
+        if (result == null || result.isEmpty()) {
+            return new ArrayList<>();
+        }
 
-            // 传输的类型
+        try {
-            httpGet.addHeader("Content-Type", "application/json");
+            // Handle potential escaped quotes in response
-            //发送请求，请求响应结果
+            if (result.startsWith("\"") && result.endsWith("\"")) {
-            CloseableHttpResponse response = httpClient.execute(httpGet);
+                result = result.substring(1, result.length() - 1).replace("\\\"", "\"").replace("\\\\", "\\");
-            //获取服务器返回的状态码
-            int statusCode = response.getStatusLine().getStatusCode();
-            System.out.println("服务端返回成功的状态码为：" + statusCode);
-            HttpEntity entity = response.getEntity();
-            String body = EntityUtils.toString(entity).replaceAll("\\\\", "");
-            System.out.println("服务端返回的数据为：" + body);
-            if (body.startsWith("\"") && body.endsWith("\"")) {
-                // 步骤3：去掉双引号
-                body = body.substring(1, body.length() - 1); // 去掉首尾的双引号
             }
 
-            Gson gson = new GsonBuilder().serializeNulls().setPrettyPrinting().create();
+            EXAGroupRespVO vo = JSON.parseObject(result, EXAGroupRespVO.class);
-            Type listType = new TypeToken<List<Object>>() {
+            List<List<String>> jsonResult = new ArrayList<>();
-            }.getType();
+            if(vo.getReturnValue().equals(1L)){
-            result = gson.fromJson(body, listType);
+                jsonResult = JSON.parseObject(vo.getGroupsJson(), new com.alibaba.fastjson.TypeReference<List<List<String>>>() {});
-
+            }
-            //关闭资源
+            return jsonResult;
-            response.close();
-            httpClient.close();
         } catch (Exception e) {
-
+            System.err.println("Failed to parse group data: " + e.getMessage());
+            System.err.println("Response was: " + result);
+            // Return empty list instead of null to prevent NullPointerException
+            return new ArrayList<>();
         }
-        return result;
+
     }
 
+//    public List<Object> getGroup(String EXA_IP) throws URISyntaxException, IOException {
+//        List<Object> result = new ArrayList<>();
+//        try {
+//            // 目标 RPC 服务的 URL
+//            String url = "http://" + EXA_IP + ":9000/exawebapi/EXAItem/GetAllGroups";
+//            //创建HttpClient对象
+//            CloseableHttpClient httpClient = HttpClients.createDefault();
+//            /*
+//             * 由于GET请求的参数都是拼装在URL地址后方，所以我们要构建一个URL，带参数
+//             */
+//            URIBuilder uriBuilder = new URIBuilder(url);
+//
+//            /** 添加参数 */
+////            uriBuilder.addParameter("ItemNames", itemNames);
+//
+//            //创建请求对象
+//            HttpGet httpGet = new HttpGet(uriBuilder.build());
+//
+//            // 传输的类型
+//            httpGet.addHeader("Content-Type", "application/json");
+//            //发送请求，请求响应结果
+//            CloseableHttpResponse response = httpClient.execute(httpGet);
+//            //获取服务器返回的状态码
+//            int statusCode = response.getStatusLine().getStatusCode();
+//            System.out.println("服务端返回成功的状态码为：" + statusCode);
+//            HttpEntity entity = response.getEntity();
+//            String body = EntityUtils.toString(entity).replaceAll("\\\\", "");
+//            System.out.println("服务端返回的数据为：" + body);
+//            if (body.startsWith("\"") && body.endsWith("\"")) {
+//                // 步骤3：去掉双引号
+//                body = body.substring(1, body.length() - 1); // 去掉首尾的双引号
+//            }
+//
+//            Gson gson = new GsonBuilder().serializeNulls().setPrettyPrinting().create();
+//            Type listType = new TypeToken<List<Object>>() {
+//            }.getType();
+//            result = gson.fromJson(body, listType);
+//
+//            //关闭资源
+//            response.close();
+//            httpClient.close();
+//        } catch (Exception e) {
+//
+//        }
+//        return result;
+//    }
+
     public String deletePoint(String EXA_IP, String ItemName) {
         String requestPathDeleteItem = "http://" + EXA_IP + ":9000/exawebapi/exaitem/DeleteItem?ItemName=" + ItemName;
         // 创建HttpClient

yudao-module-system/yudao-module-system-api/src/main/java/cn/iocoder/yudao/module/system/enums/ErrorCodeConstants.java

@@ -190,4 +190,6 @@ public interface ErrorCodeConstants {
     ErrorCode SYSTEM_CONFIG_NOT_EXISTS = new ErrorCode(1_002_033_000, "系统配置不存在");
     ErrorCode SYSTEM_CONFIG_NAME_DUPLICATE = new ErrorCode(1_002_033_001, "已经存在该名字的系统配置");
 
+    // ========== Excel 导入导出 1-002-034-000 ==========
+    ErrorCode EXCEL_FILE_EMPTY = new ErrorCode(1_002_034_000, "Excel 文件为空");
 }