rain
2024-08-21 2db1aa88e8ab53096a936163d686b90d8e056a99
src/main/java/com/dji/sample/territory/controller/TbDkjbxxController.java
@@ -74,32 +74,36 @@
    @PostMapping("/upload")
    public ResponseResult uploadFile(@RequestParam("file") MultipartFile file,
                                     @RequestParam String taskName,
                                     @RequestParam String taskId){
        String workspaceId="4a574db8-4ad3-48f7-9f16-3edbcd8056e1";
        if (file==null){
                                     @RequestParam String taskId) {
        String workspaceId = "4a574db8-4ad3-48f7-9f16-3edbcd8056e1";
        if (file == null) {
            return ResponseResult.error("上传文件为空");
        }
        tbDkjbxxService.uploadFile(file);
        List<TbDkjbxxEntity> list = tbDkjbxxService.list();
        if (list.size()==0){
        if (list.size() == 0) {
            return ResponseResult.error("上传文件数据为空");
        }
        try {
            shpToDataSourceService.savaInMysql(list, workspaceId,taskId,taskName);
        }catch (Exception e){
            shpToDataSourceService.savaInMysql(list, workspaceId, taskId, taskName);
        } catch (Exception e) {
            return ResponseResult.error("上传db文件的内容格式不匹配");
        }
        return ResponseResult.success("上传成功");
    }
    @PostMapping("/uploadUrl")
    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,param.getTaskId(),param.getTaskName());
    public ResponseResult uploadUrl(@RequestBody UploadUrlParam param) {
        try {
            tbDkjbxxService.uploadUrl(param.getDbUrl(), param.getTaskName());
            String workspaceId = "4a574db8-4ad3-48f7-9f16-3edbcd8056e1";
            List<TbDkjbxxEntity> list = tbDkjbxxService.list();
            shpToDataSourceService.savaInMysql(list, workspaceId, param.getTaskId(), param.getTaskName());
        } catch (Exception e) {
            return ResponseResult.error("文件下载发生错误" + e);
        }
        return ResponseResult.success(200);
    }