服务器上传dat文件优化

src/main/java/sys/sc/formplugin/CreatDatPlugin.java

@@ -11,6 +11,7 @@ import kd.bos.servicehelper.BusinessDataServiceHelper;
 import sys.sc.opplugin.utils.DatFileCreatUtils;
 import sys.sc.opplugin.utils.SftpClient;
 
+import java.io.File;
 import java.util.ArrayList;
 import java.util.List;
 
@@ -51,8 +52,14 @@ public class CreatDatPlugin extends AbstractListPlugin {
                             ",nckd_password,nckd_split,nckd_endsign",new QFilter[]{qFilter});
             //文件名
             String filename=tablenumber+".dat";
+            String filedir="C:\\datTemp";
             //生成文件的路径
-            String filePath="C:\\"+filename;
+            String filePath=filedir+"/"+filename;
+            File dir=new File(filedir);
+            //不存在则创建文件夹
+            if (!dir.exists()) {
+                dir.mkdirs();
+            }
             //分割符号
             String spiltsign=jkdataDy.getString("nckd_split");
             //结束符号

src/main/java/sys/sc/opplugin/utils/SftpClient.java

@@ -43,20 +43,6 @@ public class SftpClient {
         InputStream inputStream = sftpChannel.get(remoteFilePath);
         return inputStream;
     }
-
-    // 下载文件
-//    public void downloadFile(String remoteFilePath, String localFilePath) throws Exception {
-//        try (InputStream inputStream = sftpChannel.get(remoteFilePath);
-//             FileOutputStream outputStream = new FileOutputStream(localFilePath)) {
-//
-//            byte[] buffer = new byte[1024];
-//            int bytesRead;
-//            while ((bytesRead = inputStream.read(buffer)) != -1) {
-//                outputStream.write(buffer, 0, bytesRead);
-//            }
-//        }
-//    }
-
     //上传文件到服务器路径,
     public void fileCreat(String localFilePath,String remoteFilePath) throws SftpException {
         //本地服务器传到服务器文件

src/main/java/sys/sc/task/CreatDatDailyTask.java

@@ -16,6 +16,7 @@ import scala.Dynamic;
 import sys.sc.opplugin.utils.DatFileCreatUtils;
 import sys.sc.opplugin.utils.SftpClient;
 
+import java.io.File;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
@@ -70,8 +71,14 @@ public class CreatDatDailyTask extends AbstractTask {
                             ",nckd_password,nckd_split,nckd_endsign",new QFilter[]{qFilter});
             //文件名
             String filename=tablenumber+".dat";
+            String filedir="C:\\datTemp";
             //生成文件的路径
-            String filePath="C:\\"+filename;
+            String filePath=filedir+"/"+filename;
+            File dir=new File(filedir);
+            //不存在则创建文件夹
+            if (!dir.exists()) {
+                dir.mkdirs();
+            }
             //分割符号
             String spiltsign=jkdataDy.getString("nckd_split");
             //结束符号