From f2d47fa3543738676e27c5a11b975f0d6a7fee6f Mon Sep 17 00:00:00 2001
From: Administrator <admin>
Date: Thu, 09 Jun 2022 17:36:40 +0800
Subject: [PATCH] 保安员新增，导入，报名修改，修改为定时响应
---
src/main/java/org/springblade/modules/system/service/impl/UserServiceImpl.java | 414 +++++++++++++++++++++++++++++-----------------------------
1 files changed, 207 insertions(+), 207 deletions(-)
diff --git a/src/main/java/org/springblade/modules/system/service/impl/UserServiceImpl.java b/src/main/java/org/springblade/modules/system/service/impl/UserServiceImpl.java
index 85804a2..6d95a07 100644
--- a/src/main/java/org/springblade/modules/system/service/impl/UserServiceImpl.java
+++ b/src/main/java/org/springblade/modules/system/service/impl/UserServiceImpl.java
@@ -1373,116 +1373,116 @@
map.put(uuid, userList);
myAsyncService.FTPObjectList(map);
- int count = 0;
- //调用ftp获取返回数据
- while (true){
- try {
- Thread.sleep(4000);
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- //调用ftp获取返回数据
- result = Monitor.getFtpDataByUuidList(uuid);
- //如果返回true,就退处
- if (result.getCode() == 200) {
- break;
- }
- else {
- count++;
- if (count == 20) {
- break;
- }
- }
- }
+// int count = 0;
+// //调用ftp获取返回数据
+// while (true){
+// try {
+// Thread.sleep(4000);
+// } catch (InterruptedException e) {
+// e.printStackTrace();
+// }
+// //调用ftp获取返回数据
+// result = Monitor.getFtpDataByUuidList(uuid);
+// //如果返回true,就退处
+// if (result.getCode() == 200) {
+// break;
+// }
+// else {
+// count++;
+// if (count == 20) {
+// break;
+// }
+// }
+// }
}
- if (null!=result){
- //获取 result
- List<Result> data1 = result.getData();
- if (data1.size()>0){
- for (Result result1 : data1) {
- // 取出 Msg ,此 msg 存的对应的 uuid
- String uuid = result1.getMsg();
- //从redis 中获取用户数据
- Object o1 = redisTemplate.opsForValue().get(uuid);
- User user0 = JSON.parseObject(o1.toString(), User.class);
- // 从redis 中获取对应的用户信息,脱敏处理过
- User user = handlerUserInfo(uuid);
- if (result1.getCode()==200){
- user.setId(result1.getUserId());
- boolean save = this.save(user);
- //同步用户数据到群防群控
- if (save) {
- myAsyncService.qfqkUserSave(user);
- }
- //加入新增集合
-// addList.add(user);
- }
- if (result1.getCode()==201){
- //先查询当前库是否有改用户？
- User user1 = this.getById(result1.getUserId());
- if (null!=user1) {
- //存在，更新
- user.setId(result1.getUserId());
- user.setCreateTime(null);
- boolean update = this.updateById(user);
- if (update) {
- //数据异步同步到群防群控
- myAsyncService.updateUserByQfqk(user);
- }
- }else {
- //不存在，则新增
- user.setId(result1.getUserId());
- boolean save = this.save(user);
- if (save){
- //数据异步同步到群防群控
- myAsyncService.qfqkUserSave(user);
- }
- }
- //加入更新集合
-// updateList.add(user);
- }
- if (result1.getCode()==202){
- status.set(false);
- //已在其他单位存在
- errorList.add(user0.getCardid());
- }
- if (result1.getCode()==203){
- securityInvalidStatus.set(false);
- //保安证编号不匹配
- securityInvalidList.add(user0.getCardid());
- }
- }
-// //批量插入
-// if (addList.size()>0){
-// baseMapper.batchUserList(addList);
+// if (null!=result){
+// //获取 result
+// List<Result> data1 = result.getData();
+// if (data1.size()>0){
+// for (Result result1 : data1) {
+// // 取出 Msg ,此 msg 存的对应的 uuid
+// String uuid = result1.getMsg();
+// //从redis 中获取用户数据
+// Object o1 = redisTemplate.opsForValue().get(uuid);
+// User user0 = JSON.parseObject(o1.toString(), User.class);
+// // 从redis 中获取对应的用户信息,脱敏处理过
+// User user = handlerUserInfo(uuid);
+// if (result1.getCode()==200){
+// user.setId(result1.getUserId());
+// boolean save = this.save(user);
+// //同步用户数据到群防群控
+// if (save) {
+// myAsyncService.qfqkUserSave(user);
+// }
+// //加入新增集合
+//// addList.add(user);
+// }
+// if (result1.getCode()==201){
+// //先查询当前库是否有改用户？
+// User user1 = this.getById(result1.getUserId());
+// if (null!=user1) {
+// //存在，更新
+// user.setId(result1.getUserId());
+// user.setCreateTime(null);
+// boolean update = this.updateById(user);
+// if (update) {
+// //数据异步同步到群防群控
+// myAsyncService.updateUserByQfqk(user);
+// }
+// }else {
+// //不存在，则新增
+// user.setId(result1.getUserId());
+// boolean save = this.save(user);
+// if (save){
+// //数据异步同步到群防群控
+// myAsyncService.qfqkUserSave(user);
+// }
+// }
+// //加入更新集合
+//// updateList.add(user);
+// }
+// if (result1.getCode()==202){
+// status.set(false);
+// //已在其他单位存在
+// errorList.add(user0.getCardid());
+// }
+// if (result1.getCode()==203){
+// securityInvalidStatus.set(false);
+// //保安证编号不匹配
+// securityInvalidList.add(user0.getCardid());
+// }
// }
-// //批量更新
-// if (updateList.size()>0){
-// baseMapper.batchUpdateUserList(updateList);
-// }
- }
- }
+//// //批量插入
+//// if (addList.size()>0){
+//// baseMapper.batchUserList(addList);
+//// }
+//// //批量更新
+//// if (updateList.size()>0){
+//// baseMapper.batchUpdateUserList(updateList);
+//// }
+// }
+// }
- //如果所有数据导入有一个异常
- StringBuilder errorBuilder = new StringBuilder();
- if (!status.get()){
- String errorAccount = StringUtils.join(errorList, "\\\n");
- errorBuilder.append("用户:[" + errorAccount + "]导入失败!已在其他单位存在!");
- }
- if (!agetStatus.get()){
- String errorAccount = StringUtils.join(ageErrorList, "\\\n");
- errorBuilder.append("用户:[" + errorAccount + "]导入失败!身份证号码不正确,请核对!");
- }
- if (!securityInvalidStatus.get()){
- String errorAccount = StringUtils.join(securityInvalidList, "\\\n");
-// errorBuilder.append("用户:[" + errorAccount + "]保安证编号不匹配,请核实!");
- errorBuilder.append("用户:[" + errorAccount + "]保安证编号不匹配,请核实!也可通过提供保安证件信息提交核实申请!");
- }
- //抛出异常
- if (errorBuilder.length()>0){
- throw new ServiceException(errorBuilder.toString());
- }
+// //如果所有数据导入有一个异常
+// StringBuilder errorBuilder = new StringBuilder();
+// if (!status.get()){
+// String errorAccount = StringUtils.join(errorList, "\\\n");
+// errorBuilder.append("用户:[" + errorAccount + "]导入失败!已在其他单位存在!");
+// }
+// if (!agetStatus.get()){
+// String errorAccount = StringUtils.join(ageErrorList, "\\\n");
+// errorBuilder.append("用户:[" + errorAccount + "]导入失败!身份证号码不正确,请核对!");
+// }
+// if (!securityInvalidStatus.get()){
+// String errorAccount = StringUtils.join(securityInvalidList, "\\\n");
+//// errorBuilder.append("用户:[" + errorAccount + "]保安证编号不匹配,请核实!");
+// errorBuilder.append("用户:[" + errorAccount + "]保安证编号不匹配,请核实!也可通过提供保安证件信息提交核实申请!");
+// }
+// //抛出异常
+// if (errorBuilder.length()>0){
+// throw new ServiceException(errorBuilder.toString());
+// }
}
/**
@@ -1651,109 +1651,109 @@
map.put(uuid, userList);
myAsyncService.FTPObjectList(map);
- int count = 0;
- //调用ftp获取返回数据
- while (true){
- try {
- Thread.sleep(4000);
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- //调用ftp获取返回数据
- result = Monitor.getFtpDataByUuidList(uuid);
- //如果返回true,就退处
- if (result.getCode() == 200) {
- break;
- }
- else {
- count++;
- if (count == 20) {
- break;
- }
- }
- }
+// int count = 0;
+// //调用ftp获取返回数据
+// while (true){
+// try {
+// Thread.sleep(4000);
+// } catch (InterruptedException e) {
+// e.printStackTrace();
+// }
+// //调用ftp获取返回数据
+// result = Monitor.getFtpDataByUuidList(uuid);
+// //如果返回true,就退处
+// if (result.getCode() == 200) {
+// break;
+// }
+// else {
+// count++;
+// if (count == 20) {
+// break;
+// }
+// }
+// }
}
- if (null!=result){
- //获取 result
- List<Result> data1 = result.getData();
- if (data1.size()>0){
- for (Result result1 : data1) {
- // 取出 Msg ,此 msg 存的对应的 uuid
- String uuid = result1.getMsg();
- //从redis 中获取用户数据
- Object o1 = redisTemplate.opsForValue().get(uuid);
- User user0 = JSON.parseObject(o1.toString(), User.class);
- // 从redis 中获取对应的用户信息,脱敏处理过
- User user = handlerUserInfo(uuid);
- if (result1.getCode()==200){
- user.setId(result1.getUserId());
- boolean save = this.save(user);
- if (save){
- //数据异步同步到群防群控
- myAsyncService.qfqkUserSave(user);
- }
- //加入新增集合
-// addList.add(user);
- }
- //更新
- if (result1.getCode()==201){
- //先查询当前库是否有改用户？
- User user1 = this.getById(result1.getUserId());
- if (null!=user1) {
- //存在，更新
- user.setId(result1.getUserId());
- user.setCreateTime(null);
- boolean update = this.updateById(user);
- if (update) {
- //数据异步同步到群防群控
- myAsyncService.updateUserByQfqk(user);
- }
- }else {
- //不存在，则新增
- user.setId(result1.getUserId());
- boolean save = this.save(user);
- if (save){
- //数据异步同步到群防群控
- myAsyncService.qfqkUserSave(user);
- }
- }
- //加入更新集合
-// updateList.add(user);
- }
- if (result1.getCode()==202){
- status.set(false);
- //已在其他单位存在
- errorList.add(user0.getCardid());
- }
- if (result1.getCode()==203){
- securityInvalidStatus.set(false);
- //保安证编号不匹配
- securityInvalidList.add(user0.getCardid());
- }
- }
- }
- }
-
- //如果所有数据导入有一个异常
- StringBuilder errorBuilder = new StringBuilder();
- if (!status.get()){
- String errorAccount = StringUtils.join(errorList, "\\\n");
- errorBuilder.append("用户:[" + errorAccount + "]导入失败!已在其他单位存在!");
- }
- if (!agetStatus.get()){
- String errorAccount = StringUtils.join(ageErrorList, "\\\n");
- errorBuilder.append("用户:[" + errorAccount + "]导入失败!身份证号码不正确,请核对!");
- }
- if (!securityInvalidStatus.get()){
- String errorAccount = StringUtils.join(securityInvalidList, "\\\n");
- errorBuilder.append("用户:[" + errorAccount + "]保安证编号不匹配,请核实!");
-// errorBuilder.append("用户:[" + errorAccount + "]保安证编号不匹配,请核实!也可通过提供保安证件信息提交核实申请!");
- }
- //抛出异常
- if (errorBuilder.length()>0){
- throw new ServiceException(errorBuilder.toString());
- }
+// if (null!=result){
+// //获取 result
+// List<Result> data1 = result.getData();
+// if (data1.size()>0){
+// for (Result result1 : data1) {
+// // 取出 Msg ,此 msg 存的对应的 uuid
+// String uuid = result1.getMsg();
+// //从redis 中获取用户数据
+// Object o1 = redisTemplate.opsForValue().get(uuid);
+// User user0 = JSON.parseObject(o1.toString(), User.class);
+// // 从redis 中获取对应的用户信息,脱敏处理过
+// User user = handlerUserInfo(uuid);
+// if (result1.getCode()==200){
+// user.setId(result1.getUserId());
+// boolean save = this.save(user);
+// if (save){
+// //数据异步同步到群防群控
+// myAsyncService.qfqkUserSave(user);
+// }
+// //加入新增集合
+//// addList.add(user);
+// }
+// //更新
+// if (result1.getCode()==201){
+// //先查询当前库是否有改用户？
+// User user1 = this.getById(result1.getUserId());
+// if (null!=user1) {
+// //存在，更新
+// user.setId(result1.getUserId());
+// user.setCreateTime(null);
+// boolean update = this.updateById(user);
+// if (update) {
+// //数据异步同步到群防群控
+// myAsyncService.updateUserByQfqk(user);
+// }
+// }else {
+// //不存在，则新增
+// user.setId(result1.getUserId());
+// boolean save = this.save(user);
+// if (save){
+// //数据异步同步到群防群控
+// myAsyncService.qfqkUserSave(user);
+// }
+// }
+// //加入更新集合
+//// updateList.add(user);
+// }
+// if (result1.getCode()==202){
+// status.set(false);
+// //已在其他单位存在
+// errorList.add(user0.getCardid());
+// }
+// if (result1.getCode()==203){
+// securityInvalidStatus.set(false);
+// //保安证编号不匹配
+// securityInvalidList.add(user0.getCardid());
+// }
+// }
+// }
+// }
+//
+// //如果所有数据导入有一个异常
+// StringBuilder errorBuilder = new StringBuilder();
+// if (!status.get()){
+// String errorAccount = StringUtils.join(errorList, "\\\n");
+// errorBuilder.append("用户:[" + errorAccount + "]导入失败!已在其他单位存在!");
+// }
+// if (!agetStatus.get()){
+// String errorAccount = StringUtils.join(ageErrorList, "\\\n");
+// errorBuilder.append("用户:[" + errorAccount + "]导入失败!身份证号码不正确,请核对!");
+// }
+// if (!securityInvalidStatus.get()){
+// String errorAccount = StringUtils.join(securityInvalidList, "\\\n");
+// errorBuilder.append("用户:[" + errorAccount + "]保安证编号不匹配,请核实!");
+//// errorBuilder.append("用户:[" + errorAccount + "]保安证编号不匹配,请核实!也可通过提供保安证件信息提交核实申请!");
+// }
+// //抛出异常
+// if (errorBuilder.length()>0){
+// throw new ServiceException(errorBuilder.toString());
+// }
}
--
Gitblit v1.9.3