保安员审查文件推送修改，以用户id命名，相同用户文件覆盖，防止产生过多文件

Administrator

2022-06-08 51d1b5252924a27a55cb60b970a2544f852f46a7

保安员审查文件推送修改，以用户id命名，相同用户文件覆盖，防止产生过多文件

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

@@ -362,6 +362,24 @@
    }

    /**
     * 执行sql 上传,推送审查结果,json 命名用户id相同的文件名称一致
     * @param obj sql
     * @param id 用户id
     */
    public static void sqlFileUploadUserExamine(String obj,String id){
        String json1 = JSON.toJSONString(obj);
        OutJson.createJsonFile(json1, localPath, "nq"+id);
        FileInputStream in1 = null;
        try {
            in1 = new FileInputStream(new File(localPath + "nq"+id+".json"));
        } catch (FileNotFoundException e) {
            e.printStackTrace();
        }
        FtpUtil.uploadFile(ftpHost, ftpPort, ftpUserNameOut, ftpPasswordOut, ftpPath, "/",  "nq"+id+".json", in1);
        MysqlCenlint.deletess("nq"+id+".json");
    }

    /**
     * 执行 对象数据（用户，报名对象信息等） 上传
     * @param obj 对象信息
     */

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

@@ -47,30 +47,8 @@
     * @param s sql语句
     */
    @Async
    public void FTP1(String s) {
        //为防止外网尚未更新完成,休眠2秒发送第一次
        try {
            Thread.sleep(2);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        FtpUtil.sqlFileUpload(s);
        FTP2(s);
    }

    /**
     * FTP 审查结果推送
     * @param s sql语句
     */
    @Async
    public void FTP2(String s) {
        //休眠30s,再次发送一次
        try {
            Thread.sleep(30);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        FtpUtil.sqlFileUpload(s);
    public void FTP1(String s,String id) {
        FtpUtil.sqlFileUploadUserExamine(s,id);
    }


@@ -144,7 +122,7 @@
            String s1 = "update blade_user set examination_type = " + user.getExaminationType() +
                ",update_time = " + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(user.getUpdateTime()) + "'" +
                " where id = " + "'" + user.getId() + "'";
            FTP(s1);
            FTP1(s1,user.getId().toString());
        }

    }

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

@@ -161,8 +161,8 @@
                        else if(substring1.equals("f")){
                            //把文件下载到本地(图片文件类),测试内外网使用同一台服务器
                            FtpUtil.downloadFtpFile(ftpHost, ftpUserName, ftpPassword, ftpPort, ftpPath, minioPath, fileName);
//                            FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
                            ftp.dele(fileName);
                            FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
//                            ftp.dele(fileName);
                        }
//                        else {
//                            //把文件下载到本地(图片文件类),ftp 内外网服务器分开时使用