钟日健
2022-05-30 e79610c6d20c659db2063634d683f94cd9d50518
新增保安员审查
3 files modified
41 ■■■■ changed files
src/main/java/org/springblade/modules/FTP/DataHanlder.java 13 ●●●●● patch | view | raw | blame | history
src/main/java/org/springblade/modules/FTP/MyAsyncService.java 2 ●●● patch | view | raw | blame | history
src/main/java/org/springblade/modules/quartz/task/Task.java 26 ●●●● patch | view | raw | blame | history
src/main/java/org/springblade/modules/FTP/DataHanlder.java
@@ -60,6 +60,19 @@
        hanlder.iDeptService = this.iDeptService;
    }
    /**
     * 保安员审查
     * @param json
     */
    public static void handlerUserExamine(String json) {
        User user = JSON.parseObject(json, User.class);
        //获取用户cardid
        User user1 = hanlder.userService.getById(user.getId());
        //用户审查
        hanlder.myAsyncService.checkUserExamineByCardNo(user1);
    }
    /**
     * 获取保安员证编号
     * @param json
src/main/java/org/springblade/modules/FTP/MyAsyncService.java
@@ -144,7 +144,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() + "'";
            FTP1(s1);
            FTP(s1);
        }
    }
src/main/java/org/springblade/modules/quartz/task/Task.java
@@ -101,7 +101,8 @@
                            //删除本地文件
                            MysqlCenlint.deletess(fileName);
                            //删除 ftp 文件
                            FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
                            ftp.dele(fileName);
//                            FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
                        }else if(substring1.equals("o")){
                            //获取对象字符串
                            String json = OutJson.TestJson(fileName);
@@ -110,7 +111,8 @@
                            //删除本地文件
                            MysqlCenlint.deletess(fileName);
                            //删除 ftp 文件
                            FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
                            ftp.dele(fileName);
//                            FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
                        }else if(substring1.equals("l")){
                            //用户集合数据,批量导入用户
                            //获取对象字符串
@@ -130,7 +132,8 @@
                            //删除本地文件
                            MysqlCenlint.deletess(fileName);
                            //删除 ftp 文件
                            FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
                            ftp.dele(fileName);
//                            FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
                        }else if(substring1.equals("s")){
                            //获取保安员证编号数据
                            //获取对象字符串
@@ -140,12 +143,25 @@
                            //删除本地文件
                            MysqlCenlint.deletess(fileName);
                            //删除 ftp 文件
                            FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
                            ftp.dele(fileName);
//                            FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
                        }else if(substring1.equals("u")){
                            //保安员审查
                            //获取对象字符串
                            String json = OutJson.TestJson(fileName);
                            //数据处理
                            DataHanlder.handlerUserExamine(json);
                            //删除本地文件
                            MysqlCenlint.deletess(fileName);
                            //删除 ftp 文件
                            ftp.dele(fileName);
//                            FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
                        }
                        else if(substring1.equals("f")){
                            //把文件下载到本地(图片文件类),测试内外网使用同一台服务器
                            FtpUtil.downloadFtpFile(ftpHost, ftpUserName, ftpPassword, ftpPort, ftpPath, minioPath, fileName);
                            FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
//                            FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
                            ftp.dele(fileName);
                        }
//                        else {
//                            //把文件下载到本地(图片文件类),ftp 内外网服务器分开时使用