设备台账完善-导入接口暂存

@@ -5,10 +5,16 @@ import io.swagger.annotations.ApiOperation;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
+import org.apache.poi.ss.usermodel.Cell;
+import org.apache.poi.ss.usermodel.Row;
+import org.apache.poi.ss.usermodel.Sheet;
+import org.apache.poi.ss.usermodel.Workbook;
+import org.apache.poi.xssf.usermodel.XSSFWorkbook;
 import org.springframework.http.ResponseEntity;
 import org.springframework.security.access.prepost.PreAuthorize;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
 import org.thingsboard.server.common.data.exception.ThingsboardException;
 import org.thingsboard.server.common.data.yunteng.common.DeleteGroup;
 import org.thingsboard.server.common.data.yunteng.dto.BrainDeviceDTO;
@@ -18,7 +24,10 @@ import org.thingsboard.server.controller.BaseController;
 import org.thingsboard.server.dao.yunteng.service.BrainDeviceService;
 import org.thingsboard.server.queue.util.TbCoreComponent;
 
+import java.io.InputStream;
+import java.util.ArrayList;
 import java.util.HashMap;
+import java.util.List;
 import java.util.Map;
 
 import static org.thingsboard.server.common.data.yunteng.constant.QueryConstant.PAGE;
@@ -91,4 +100,67 @@ public class BrainDeviceController extends BaseController {
         return ResponseResult.success(true);
     }
 
+    @PostMapping("/import")
+    public Map<String, Object> importDevices(@RequestParam("file") MultipartFile file) {
+        Map<String, Object> result = new HashMap<>();
+        List<String> errors = new ArrayList<>();
+        int successCount = 0;
+        //此接口未完成
+        try (InputStream inputStream = file.getInputStream()) {
+            Workbook workbook = new XSSFWorkbook(inputStream);
+            Sheet sheet = workbook.getSheetAt(0);
+
+            for (int i = 1; i <= sheet.getLastRowNum(); i++) {
+                Row row = sheet.getRow(i);
+                if (row == null) {
+                    continue;
+                }
+                try {
+                    // 4. 解析单元格
+                    String deviceId = getCellValue(row.getCell(0));
+                    String deviceName = getCellValue(row.getCell(1));
+                    String deviceType = getCellValue(row.getCell(2));
+
+                    // 5. 数据校验逻辑
+                    if(deviceId.isEmpty() || deviceName.isEmpty()){
+                        throw new Exception("必填字段为空");
+                    }
+
+                    // 6. 调用Service层保存设备（伪代码）
+                    // deviceService.save(new Device(deviceId, deviceName, deviceType));
+                    successCount++;
+
+                } catch (Exception e) {
+                    errors.add("第" + (i+1) + "行数据异常：" + e.getMessage());
+                }
+            }
+            result.put("success", true);
+            result.put("total", successCount + errors.size());
+            result.put("successCount", successCount);
+            result.put("errorList", errors);
+
+        } catch (Exception e) {
+            result.put("success", false);
+            result.put("message", "文件处理失败：" + e.getMessage());
+        }
+        return result;
+    }
+
+    // 通用单元格值获取方法
+    private String getCellValue(Cell cell) {
+        if (cell == null) return "";
+
+        switch (cell.getCellType()) {
+            case STRING:
+                return cell.getStringCellValue().trim();
+            case NUMERIC:
+                return String.valueOf((int)cell.getNumericCellValue());
+            case BOOLEAN:
+                return String.valueOf(cell.getBooleanCellValue());
+            default:
+                return "";
+        }
+    }
+
+
 }