新增任务

Administrator

2022-05-18 80e1bfbfd98c8213cd19a2efb021e6e7902fc799

新增任务

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

@@ -47,7 +47,6 @@
                return new Result(400,null,"ftp 连接失败",null);
            }


            ftp.enterLocalActiveMode();



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

@@ -55,6 +55,102 @@
        trainingRegistrationService.examLoading();
    }

    /**
     * 读取内外推送的文件,每30秒读取一次
     * @return
     */
//    @Scheduled(cron = "*/30 * * * * ?")
    public boolean readFile() {
        FTPClient ftp = new FTPClient();
        try {
            //连接
            ftp.connect(ftpHost, ftpPort);
            // 登陆
            ftp.login(ftpUserNameIn, ftpPasswordIn);
            // 检验登陆操作的返回码是否正确
            if (!FTPReply.isPositiveCompletion(ftp.getReplyCode())) {
                ftp.disconnect();
                return false;
            }

            ftp.enterLocalActiveMode();

            // 设置文件类型为二进制，与ASCII有区别
            ftp.setFileType(FTP.BINARY_FILE_TYPE);

            // 设置编码格式
            ftp.setControlEncoding("GBK");

            // 检验文件是否存在
            ftp.changeWorkingDirectory(ftpPath);

            // Use passive mode as default
            ftp.enterLocalPassiveMode();

            FTPFile[] files = ftp.listFiles();
            if (files.length==0){
                return false;
            }
            else {
                for (FTPFile file : files) {
                    String fileName = file.getName();
                    InputStream is = ftp.retrieveFileStream(new String(fileName.getBytes("GBK"), FTP.DEFAULT_CONTROL_ENCODING));
                    if (null == is) {
                        return false;
                    } else {
                        String substring1 = fileName.substring(0, 4);
                        if (substring1.equals("nsql")) {
                            //把文件下载到本地
                            FtpUtil.downloadFtpFile(ftpHost, ftpUserNameIn, ftpPasswordIn, 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);
                                }
                            }
                            //删除本地服务器文件
                            MysqlCenlint.deletess(fileName);
                            //删除 ftp 服务器文件
                            FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName);
                        }
                        //关闭流
                        is.close();
                        ftp.completePendingCommand();
                    }
                    return true;
                }
            }
        } catch (Exception e) {
            System.out.println("ftp连接失败");
            e.printStackTrace();
        } finally {
            if (ftp != null) {
                try {
                    ftp.disconnect();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
        return false;
    }

//    /**
//     * 读取文件（用户对象）单用户新增
//     * @return