ftp 账号名修改

Administrator

2021-08-24 4120d33fd6fae0fe05b8af0c45ae6b9ccebe6723

ftp 账号名修改

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

@@ -1,5 +1,8 @@
package org.springblade.common.constant;

/**
 * @author zhongrj
 */
public interface FtpConstant {

    /**
@@ -22,7 +25,8 @@
    int ftpPort = 21;

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


    //ftp服务器密码

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

@@ -19,7 +19,7 @@
    //private static String fileName = "nsql.json";


    //@Scheduled(cron = "*/30 * * * * ?")
    @Scheduled(cron = "*/30 * * * * ?")
    public static boolean isFTPFileExist() {

        FTPClient ftp = new FTPClient();
@@ -75,38 +75,42 @@
                for (FTPFile file : files){
                    String fileName = file.getName();
                    InputStream is = ftp.retrieveFileStream(new String(fileName.getBytes("GBK"), FTP.DEFAULT_CONTROL_ENCODING));
                    String substring1 = fileName.substring(0, 1);
                    if (substring1.equals("w")) {
                        //把文件下载到本地
                        FtpUtil.downloadFtpFile(ftpHost_dev, ftpUserName, ftpPassword, ftpPort, ftpPath, localPath, fileName);
                        //
                        String s = OutJson.TestJson(fileName);
                        //sql语句
                        String sql = OutJson.stringReplace(s);
                        String[] split = sql.split(";");//以逗号分割
                        for (String sqls : split) {
                            //判断是否是新增，删除，修改
                            String substring = sqls.substring(0, 2);
                            //新增
                            if (substring.equals("in")) {
                                //运行sql语句
                                MysqlCenlint.inster(sqls);
                    if (null==is){
                        return false;
                    }else {
                        String substring1 = fileName.substring(0, 1);
                        if (substring1.equals("w")) {
                            //把文件下载到本地
                            FtpUtil.downloadFtpFile(ftpHost_dev, ftpUserName, ftpPassword, ftpPort, ftpPath, localPath, fileName);
                            //
                            String s = OutJson.TestJson(fileName);
                            //sql语句
                            String sql = OutJson.stringReplace(s);
                            String[] split = sql.split(";");//以逗号分割
                            for (String sqls : split) {
                                //判断是否是新增，删除，修改
                                String substring = sqls.substring(0, 2);
                                //新增
                                if (substring.equals("in")) {
                                    //运行sql语句
                                    MysqlCenlint.inster(sqls);
                                }
                                //修改
                                else if (substring.equals("up")) {
                                    MysqlCenlint.update(sqls);
                                }
                                //删除
                                else {
                                    MysqlCenlint.delete(sqls);
                                }
                            }
                            //修改
                            else if (substring.equals("up")) {
                                MysqlCenlint.update(sqls);
                            }
                            //删除
                            else {
                                MysqlCenlint.delete(sqls);
                            }
                        }
                        //删除本地文件
                            //删除本地文件
//                        MysqlCenlint.deletes(fileName);
                        MysqlCenlint.deletess(fileName);
                        FtpUtil.deleteFile(ftpHost_dev, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
                        is.close();
                        ftp.completePendingCommand();
                            MysqlCenlint.deletess(fileName);
                            FtpUtil.deleteFile(ftpHost_dev, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
                            is.close();
                            ftp.completePendingCommand();
                        }
                    }
                }
                return true;