ftp 处理文件逻辑修改

Administrator

2022-06-13 59956d6214ece888390f415f6d8c68b0e0ce5bc3

 src/main/java/org/springblade/modules/quartz/task/Task.java

@@ -78,20 +78,22 @@
                  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);
                     if (sqls.length()>1) {
                        //判断是否是新增，删除，修改
                        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);
                        }
                     }
                  }
                  //删除本地文件
@@ -194,7 +196,7 @@
         }
      } catch (Exception e) {
         MysqlCenlint.deletess(fileName);
//         FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
         FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
         e.printStackTrace();
      } finally {
         try {