1.ftp

tangzy

2021-08-22 30436febfa0201f2e3f03eae09dae379fa7f8d70

1.ftp

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

@@ -79,45 +79,47 @@
            if (files.length==0){
                return false;
            }
            for (FTPFile file : files){
                String fileName = file.getName();
                String substring1 = fileName.substring(0, 1);
                if (substring1.equals("w")) {
                    //把文件下载到本地
                    FtpUtil.downloadFtpFile(ftpHost, 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 {
                for (FTPFile file : files){
                    String fileName = file.getName();
                    String substring1 = fileName.substring(0, 1);
                    if (substring1.equals("w")) {
                        //把文件下载到本地
                        FtpUtil.downloadFtpFile(ftpHost, 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, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
                        //is.close();
                        ftp.completePendingCommand();
                    }
                    //删除本地文件
                    MysqlCenlint.deletes(fileName);
                    MysqlCenlint.deletess(fileName);
                    FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
                    //is.close();
                    ftp.completePendingCommand();
                    return true;
                }
                return true;
            }


            //InputStream is = ftp.retrieveFileStream(new String(file.getBytes("GBK"), FTP.DEFAULT_CONTROL_ENCODING));

//            if (is == null || ftp.getReplyCode() == FTPReply.FILE_UNAVAILABLE) {