From 38f0e3224ddaca7d71eacac0441b559a1bd7cc9a Mon Sep 17 00:00:00 2001
From: rain <167982779@qq.com>
Date: Thu, 09 May 2024 17:12:59 +0800
Subject: [PATCH] 完成成果数据入库(DB)方式,修改DB文件上传接口。

---
 src/main/java/com/dji/sample/territory/controller/TbDkjbxxController.java |   22 +++++++++++++++-------
 1 files changed, 15 insertions(+), 7 deletions(-)

diff --git a/src/main/java/com/dji/sample/territory/controller/TbDkjbxxController.java b/src/main/java/com/dji/sample/territory/controller/TbDkjbxxController.java
index 2504f70..5bf93b6 100644
--- a/src/main/java/com/dji/sample/territory/controller/TbDkjbxxController.java
+++ b/src/main/java/com/dji/sample/territory/controller/TbDkjbxxController.java
@@ -76,23 +76,31 @@
                                      @RequestParam String taskName,
                                      @RequestParam String taskId){
         String workspaceId="4a574db8-4ad3-48f7-9f16-3edbcd8056e1";
+        if (file==null){
+            return ResponseResult.error("上传文件为空");
+        }
         tbDkjbxxService.uploadFile(file);
         List<TbDkjbxxEntity> list = tbDkjbxxService.list();
-        shpToDataSourceService.savaInMysql(list, workspaceId,taskId,taskName);
+        if (list.size()==0){
+            return ResponseResult.error("上传文件数据为空");
+        }
+        try {
+            shpToDataSourceService.savaInMysql(list, workspaceId,taskId,taskName);
+        }catch (Exception e){
+            return ResponseResult.error("上传db文件的内容格式不匹配");
+        }
         return ResponseResult.success("上传成功");
     }
 
 
 
     @PostMapping("/uploadUrl")
-    public ResponseResult uploadUrl( @RequestParam String url,
-                                     @RequestParam String taskName,
-                                     @RequestParam String taskId){
-        tbDkjbxxService.uploadUrl(url);
+    public ResponseResult uploadUrl( @RequestBody UploadUrlParam param){
+        tbDkjbxxService.uploadUrl(param.getDbUrl());
         String workspaceId="4a574db8-4ad3-48f7-9f16-3edbcd8056e1";
         List<TbDkjbxxEntity> list = tbDkjbxxService.list();
-        shpToDataSourceService.savaInMysql(list, workspaceId,taskId,taskName);
-        return ResponseResult.success("上传成功");
+        shpToDataSourceService.savaInMysql(list, workspaceId,param.getTaskId(),param.getTaskName());
+        return ResponseResult.success(200);
     }
 
     /**

--
Gitblit v1.9.3