调整删除文件逻辑

Administrator

2022-06-09 b367ef20f7fb5be71610dd89b18bde7d99a2647d

调整删除文件逻辑

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

@@ -114,8 +114,10 @@
     * @return
     */
    public static User handlerUserInfo(String uuid){
        User user2 = new User();
        //从redis 中获取用户数据
        Object o1 = handler.redisTemplate.opsForValue().get(uuid);
        if (null!=o1){
        User user = JSON.parseObject(o1.toString(), User.class);
        //取出后将 redis 删除
        handler.redisTemplate.delete(uuid);
@@ -144,4 +146,7 @@
        //返回
        return user1;
    }
        //返回null
        return user2;
    }
}

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

@@ -240,15 +240,20 @@
                            //转换
                            result = JSON.parseObject(value.toString(), Result.class);
                        }
                        if (null!=result) {
                            //异步用户处理逻辑
                            userInfoHandler(uuid,result);
                        }
                        //删除本地文件
                        MysqlCenlint.deletess(fileName);
                        //删除 ftp 文件
                        FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName);
                        System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())+"：成功删除ftp文件 = " + fileName);
                        if (null!=result) {
                            try {
                                userInfoHandler(uuid, result);
                            }catch (Exception e) {
                                //异步用户处理逻辑
                                e.printStackTrace();
                            }
                        }

                    }
                }
                //关闭流
@@ -470,6 +475,7 @@
    public void userInfoHandler(String uuid, Result result){
        //用户数处理
        User users = handlerUserInfo(uuid);
        if (null!=users) {
        System.out.println("用户数据 = " + users);
        //判断结果
        if (result.getCode()==200){
@@ -536,6 +542,7 @@
            }
        }
    }
    }


}