1.ftp

tangzy

2021-08-22 23e835592a16ce55f5ce57be118dd12d8d71e654

1.ftp

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

@@ -81,36 +81,39 @@
            }
            for (FTPFile file : files){
                String fileName = file.getName();
                //把文件下载到本地
                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);
                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);
                    FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
                    //is.close();
                    ftp.completePendingCommand();
                    return true;
                }
                //删除本地文件
                MysqlCenlint.deletes(fileName);
                FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
                //is.close();
                ftp.completePendingCommand();
                return true;
            }

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