| | |
| | | agetStatus.set(false); |
| | | ageErrorList.add(user.getCardid()); |
| | | // throw new ServiceException("导入失败!身份证号码[ "+user.getCardid()+" ]不正确,请核对!"); |
| | | //forEach 只能使用 return 跳出本次循环 |
| | | // return; |
| | | continue; |
| | | } |
| | | } |
| | |
| | | // addList.add(user); |
| | | } |
| | | if (result1.getCode()==201){ |
| | | user.setId(result1.getUserId()); |
| | | user.setCreateTime(null); |
| | | this.updateById(user); |
| | | //先查询当前库是否有改用户? |
| | | 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); |
| | | } |
| | |
| | | //加入新增集合 |
| | | // addList.add(user); |
| | | } |
| | | //更新 |
| | | if (result1.getCode()==201){ |
| | | user.setId(result1.getUserId()); |
| | | user.setCreateTime(null); |
| | | boolean update = this.updateById(user); |
| | | if (update){ |
| | | //数据异步同步到群防群控 |
| | | myAsyncService.updateUserByQfqk(user); |
| | | //先查询当前库是否有改用户? |
| | | 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); |