上传dat文件

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

@@ -51,10 +51,14 @@ public class CreatDatPlugin extends AbstractListPlugin {
                             ",nckd_port,nckd_url,nckd_filename,nckd_user" +
                             ",nckd_password,nckd_split,nckd_endsign",new QFilter[]{qFilter});
             //文件名
+//            if (nckd_url.equals("/var/appstatic/")) {
+//                nckd_url="/home/kingdee/cosmic/nginx-appstatic/store/appstatic/";
+//            }
             String filename=tablenumber+".dat";
-            String filedir="C:\\datTemp";
+//            String filedir="C:\\datTemp";
+            String filedir="/home/kingdee/cosmic/nginx-appstatic/store/appstatic/";
             //生成文件的路径
-            String filePath=filedir+"/"+filename;
+            String filePath=filedir+filename;
             File dir=new File(filedir);
             //不存在则创建文件夹
             if (!dir.exists()) {
@@ -79,17 +83,17 @@ public class CreatDatPlugin extends AbstractListPlugin {
             String nckd_url=jkdataDy.getString("nckd_url");
             //服务器端口号
             int port=jkdataDy.getInt("nckd_port");
-            SftpClient sftpClient=new SftpClient(host,username,password,port);
-            //获取服务器连接
-            try {
-                sftpClient.connect();
-                //上传文件到服务器指定路径
-                sftpClient.fileCreat(filePath,nckd_url+filename);
-                //关闭连接
-                sftpClient.disconnect();
-            } catch (Exception e) {
-                throw new RuntimeException(e);
-            }
+//            SftpClient sftpClient=new SftpClient(host,username,password,port);
+//            //获取服务器连接
+//            try {
+//                sftpClient.connect();
+//                //上传文件到服务器指定路径
+//                sftpClient.fileCreat(filePath,nckd_url+filename);
+//                //关闭连接
+//                sftpClient.disconnect();
+//            } catch (Exception e) {
+//                throw new RuntimeException(e);
+//            }
         }
 
     }

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

@@ -46,8 +46,10 @@ public class DatFileCreatUtils {
         this.filePath=filePath;
         this.spiltsign=spiltsign;
         this.endsign=endsign;
+
     }
 
+    //传服务器连接
     public void creatDatFile() {
         QFilter filtercol=new QFilter("number",QCP.equals,bizappnum);
         //业务云
@@ -67,6 +69,8 @@ public class DatFileCreatUtils {
                 }
                 file.createNewFile();
             }
+            //获取服务器连接
+
             try (BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(filePath), "GBK"))) {
                 while(dataSet.hasNext()) {
                     Row data = dataSet.next();

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

@@ -11,7 +11,9 @@ import com.jcraft.jsch.Session;
 import com.jcraft.jsch.SftpException;
 
 import java.io.FileOutputStream;
+import java.io.IOException;
 import java.io.InputStream;
+import java.io.OutputStream;
 
 public class SftpClient {
     private String host;
@@ -43,10 +45,13 @@ public class SftpClient {
         InputStream inputStream = sftpChannel.get(remoteFilePath);
         return inputStream;
     }
+
+
     //上传文件到服务器路径,
     public void fileCreat(String localFilePath,String remoteFilePath) throws SftpException {
         //本地服务器传到服务器文件
         sftpChannel.put(localFilePath,remoteFilePath);
+
     }
 
     // 断开连接

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

@@ -74,11 +74,7 @@ public class CreatDatDailyTask extends AbstractTask {
             String filedir="C:\\datTemp";
             //生成文件的路径
             String filePath=filedir+"/"+filename;
-            File dir=new File(filedir);
-            //不存在则创建文件夹
-            if (!dir.exists()) {
-                dir.mkdirs();
-            }
+
             //分割符号
             String spiltsign=jkdataDy.getString("nckd_split");
             //结束符号