用戶同步修改

钟日健

2022-04-27 b062ae1ee5a2a360eb9d0db4b500f4f6e1489712

用戶同步修改

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

@@ -50,7 +50,8 @@
            //获取 uuid
            String uuid = user1.getReasonForLeav();
            //用户数据校验
            R result = userCheckOut(user1);
            Result result = userCheckOut(user1);
            System.out.println("result = " + result);
            //创建返回对象
            Result result1 = new Result();
            if (result.getCode()==200){
@@ -64,7 +65,7 @@
            }else if (result.getCode()==201){
                //去修改
                user1.setReasonForLeav("");
                User data =(User) result.getData();
                User data = result.getUser();
                user1.setId(data.getId());
                hanlder.userService.updateById(user1);
                //设置返回结果
@@ -78,6 +79,7 @@
                result1.setUserId(null);
                result1.setMsg(result.getMsg());
            }
            System.out.println("result1 = " + result1);
            Map<String, Object> map1 = new HashMap<>(1);
            map1.put(uuid,result1);
            //向外网发送数据
@@ -89,7 +91,7 @@
     * 用户校验
     * @param user
     */
    private static R userCheckOut(User user) {
    private static Result userCheckOut(User user) {
        //1. 校验是否有重复导入
        User user1 = new User();
        user1.setCardid(user.getCardid());
@@ -98,13 +100,18 @@
        User one = hanlder.userService.getOne(Condition.getQueryWrapper(user1));
        if (null!=one){
            //判断单位是否一致
            if (one.getDeptId().equals(user.getDeptId())){
                R.data(400,null,user.getRealName() + "已在其他单位导入");
            if (!one.getDeptId().equals(user.getDeptId())){
                return new Result(400,null,user.getRealName() + "已在其他单位导入");
            }else {
                R.data(201,one,"已在本单位导入");
                return new Result(201,"已在本单位导入",one);
            }
        }
        return R.data(200,null,"");

        //2.保安证编号校验



        return new Result(200,null,"");
    }



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

@@ -40,7 +40,7 @@
                if(ftpClient.login(ftpUserName, ftpPassword)) {
                    //判断FTP连接是否可用，源码中是通过判断ReplyCode值（200=< reply <300)
                    if(FTPReply.isPositiveCompletion(ftpClient.getReplyCode())) {
                        logger.info("FTP连接成功。");
//                        logger.info("FTP连接成功。");
                        System.out.println("FTP登录成功,ftpHost: ftp:/"+ftpClient.getRemoteAddress());
                        ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
                    }

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

@@ -51,7 +51,7 @@
                logger.info("未连接到FTP，用户名或密码错误。");
                ftpClient.disconnect();
            } else {
                logger.info("FTP连接成功。");
//                logger.info("FTP连接成功。");
            }
        } catch (SocketException e) {
            e.printStackTrace();

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

@@ -1,6 +1,7 @@
package org.springblade.modules.FTP;

import lombok.Data;
import org.springblade.modules.system.entity.User;

/**
 * 响应对象
@@ -14,4 +15,21 @@
    private Long userId;

    private String msg;

    private User user;

    public Result(Integer code, String msg, User user) {
        this.code = code;
        this.msg = msg;
        this.user = user;
    }

    public Result() {
    }

    public Result(Integer code, Long userId, String msg) {
        this.code = code;
        this.userId = userId;
        this.msg = msg;
    }
}