ftp 路径修改

Administrator

2021-08-22 3957143d957ff4edd7319a37a2640b70d1ac0717

ftp 路径修改

 src/main/java/org/springblade/common/constant/FtpConstant.java

New file
@@ -0,0 +1,39 @@
package org.springblade.common.constant;

public interface FtpConstant {

    /**
     * sql connect
     */
    String sql_connect_test = "jdbc:mysql://223.82.109.183:2083/zhba";

    /**
     * sql connect
     */
    String sql_connect_dev = "jdbc:mysql://localhost:3306/zhba";

    //ftp服务器IP地址
    String ftpHost_test = "192.168.0.105";

    //ftp服务器IP地址
    String ftpHost_dev = "47.49.21.194";

    //ftp服务器端口
    int ftpPort = 21;

    //ftp服务器用户名
    String ftpUserName = "yly";


    //ftp服务器密码
    String ftpPassword = "Yly@123";


    //ftp服务器路径
    String ftpPath = "anbao/";

    /**
     * 本地路径
     */
    String localPath = "/home/song/anbao";
}

 src/main/java/org/springblade/modules/FTP/MysqlCenlint.java

@@ -7,6 +7,9 @@
import java.sql.PreparedStatement;
import java.sql.SQLException;

import static org.springblade.common.constant.FtpConstant.localPath;
import static org.springblade.common.constant.FtpConstant.sql_connect_dev;

public class MysqlCenlint {

    /**
@@ -18,7 +21,7 @@
            int ColumnCount;
            //int RowCount;
            String driver = "com.mysql.jdbc.Driver";
            String url = "jdbc:mysql://223.82.109.183:2083/zhba"; //换成要连接的数据库信息
            String url = sql_connect_dev; //换成要连接的数据库信息
            String user = "root";
            String password = "zhba0728";
            Class.forName ( driver );
@@ -47,7 +50,7 @@
            int ColumnCount;
            //int RowCount;
            String driver = "com.mysql.jdbc.Driver";
            String url = "jdbc:mysql://223.82.109.183:2083/zhba"; //换成要连接的数据库信息
            String url = sql_connect_dev; //换成要连接的数据库信息
            String user = "root";
            String password = "zhba0728";
            Class.forName ( driver );
@@ -76,7 +79,7 @@
            int ColumnCount;
            //int RowCount;
            String driver = "com.mysql.jdbc.Driver";
            String url = "jdbc:mysql://223.82.109.183:2083/zhba"; //换成要连接的数据库信息
            String url = sql_connect_dev; //换成要连接的数据库信息
            String user = "root";
            String password = "zhba0728";
            Class.forName ( driver );
@@ -109,7 +112,7 @@
     * 删除本地文件
     */
    public  static  void deletess(String fileName){
        File file = new File("D:\\anbao\\"+fileName);
        File file = new File(localPath+fileName);
        if (file.isFile() && file.exists()) {
            file.delete();
        }

 src/main/java/org/springblade/modules/FTP/monitor.java

@@ -10,20 +10,11 @@
import java.io.IOException;
import java.io.InputStream;

import static org.springblade.common.constant.FtpConstant.*;

@Component
public class monitor {
    //ftp服务器IP地址
    private static String ftpHost = "192.168.0.105";
    //ftp服务器端口
    private static int ftpPort = 21;
    //ftp服务器用户名
    private static String ftpUserName = "yly";
    //ftp服务器密码
    private static String ftpPassword = "Yly@123";
    //ftp服务器路径
    private static String ftpPath = "anbao/";
    //本地路径
    private static String localPath = "D:\\anbao";

    //文件名
    //private static String fileName = "nsql.json";

@@ -37,7 +28,7 @@

            // 连接ftp服务器

            ftp.connect(ftpHost, ftpPort);
            ftp.connect(ftpHost_dev, ftpPort);

            // 登陆

@@ -87,7 +78,7 @@
                    String substring1 = fileName.substring(0, 1);
                    if (substring1.equals("w")) {
                        //把文件下载到本地
                        FtpUtil.downloadFtpFile(ftpHost, ftpUserName, ftpPassword, ftpPort, ftpPath, localPath, fileName);
                        FtpUtil.downloadFtpFile(ftpHost_dev, ftpUserName, ftpPassword, ftpPort, ftpPath, localPath, fileName);
                        //
                        String s = OutJson.TestJson(fileName);
                        //sql语句
@@ -111,9 +102,9 @@
                            }
                        }
                        //删除本地文件
                        MysqlCenlint.deletes(fileName);
//                        MysqlCenlint.deletes(fileName);
                        MysqlCenlint.deletess(fileName);
                        FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
                        FtpUtil.deleteFile(ftpHost_dev, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
                        is.close();
                        ftp.completePendingCommand();
                    }