| | |
|---|
| | | |
|---|
| | | int count = 0; |
|---|
| | | int flag = 1; |
|---|
| | | Result result = new Result(); |
|---|
| | | Result result0 = new Result(); |
|---|
| | | //调用ftp获取返回数据 |
|---|
| | | while (true){ |
|---|
| | | System.out.println("用户新增开始接收消息......................"); |
|---|
| | | Thread.sleep(2000); |
|---|
| | | //调用ftp获取返回数据 |
|---|
| | | result = Monitor.isFTPFileExist(uuid); |
|---|
| | | result0 = Monitor.isFTPFileExist(uuid); |
|---|
| | | System.out.println("result0 ftp 返回结果 = " + result0); |
|---|
| | | //如果返回true,就退处 |
|---|
| | | if (result.getCode()==200){ |
|---|
| | | if (result0.getCode()==200){ |
|---|
| | | break; |
|---|
| | | }else{ |
|---|
| | | //计数 |
|---|
| | |
|---|
| | | //导入状态，默认为true ,如果有一个出现问题则为 false |
|---|
| | | AtomicBoolean status = new AtomicBoolean(true); |
|---|
| | | AtomicBoolean securityInvalidStatus = new AtomicBoolean(true); |
|---|
| | | if (null!=result){ |
|---|
| | | if (null!=result0){ |
|---|
| | | Result result = result0.getData().get(0); |
|---|
| | | //用户数处理 |
|---|
| | | User users = handlerUserInfo(uuid); |
|---|
| | | System.out.println("用户数据处理---------------"); |
|---|
| | |
|---|
| | | boolean b = userService.updateById(users); |
|---|
| | | if (b) { |
|---|
| | | //异步同步到群防群控 |
|---|
| | | myAsyncService.updateUserByQfqk(user); |
|---|
| | | myAsyncService.updateUserByQfqk(users); |
|---|
| | | } |
|---|
| | | }else { |
|---|
| | | //新增 |
|---|
