| | |
| | | import org.springblade.core.tool.utils.BeanUtil; |
| | | import org.springblade.modules.system.entity.User; |
| | | import org.springblade.modules.system.service.IUserService; |
| | | import org.springblade.modules.system.service.MyAsyncService; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.data.redis.core.RedisTemplate; |
| | | import org.springframework.stereotype.Component; |
| | |
| | | @Autowired |
| | | private RedisTemplate redisTemplate; |
| | | |
| | | @Autowired |
| | | private MyAsyncService myAsyncService; |
| | | |
| | | |
| | | /** |
| | | * 初始化 |
| | |
| | | handler = this; |
| | | handler.userService = this.userService; |
| | | handler.redisTemplate = this.redisTemplate; |
| | | handler.myAsyncService = this.myAsyncService; |
| | | } |
| | | |
| | | /** |
| | |
| | | // boolean save = handler.userService.insert(user); |
| | | boolean save = handler.userService.save(user); |
| | | if (save){ |
| | | //异步同步到群防群控 |
| | | handler.myAsyncService.qfqkUserSave(user); |
| | | //返回 |
| | | return new Result(200,null,"新增成功",null); |
| | | }else { |
| | | return new Result(400,null,"新增失败",null); |
| | | return new Result(205,null,"新增失败",null); |
| | | } |
| | | }else if (result.getCode()==201) { |
| | | //修改 |
| | |
| | | user.setId(result.getUserId()); |
| | | //数据修改 |
| | | boolean b = handler.userService.updateById(user); |
| | | System.out.println("修改状态 = " + b); |
| | | if (b) { |
| | | //异步同步到群防群控 |
| | | handler.myAsyncService.updateUserByQfqk(user); |
| | | //返回 |
| | | return new Result(200, null, "修改成功", null); |
| | | } else { |
| | | return new Result(400, null, "修改失败", null); |
| | | return new Result(205, null, "修改失败", null); |
| | | } |
| | | }else if (result.getCode()==203){ |
| | | //新增 |
| | |
| | | user.setId(result.getUserId()); |
| | | //插入数据库 |
| | | boolean save = handler.userService.save(user); |
| | | if (save) { |
| | | //异步同步到群防群控 |
| | | handler.myAsyncService.qfqkUserSave(user); |
| | | } |
| | | //失败,返回保安员证编号校验失败消息 |
| | | return new Result(203,null,result.getMsg(),null); |
| | | }else if (result.getCode()==204){ |
| | |
| | | user.setId(result.getUserId()); |
| | | //数据修改 |
| | | boolean b = handler.userService.updateById(user); |
| | | if (b){ |
| | | //异步同步到群防群控 |
| | | handler.myAsyncService.updateUserByQfqk(user); |
| | | } |
| | | //失败,返回保安员证编号校验失败消息 |
| | | return new Result(202,null,result.getMsg(),null); |
| | | }else { |
| | |
| | | //返回的user,需处理敏感数据 |
| | | User user1 = Objects.requireNonNull(BeanUtil.copy(user,User.class)); |
| | | //敏感数据处理 |
| | | user1.setRealName(DesensitizedUtil.desensitizedName(user.getRealName())); |
| | | user1.setCardid(DesensitizedUtil.desensitizedIdNumberBy4(user.getCardid())); |
| | | user1.setPhone(DesensitizedUtil.desensitizedPhoneNumber(user.getPhone())); |
| | | user1.setRegistered(DesensitizedUtil.desensitizedAddress(user.getRegistered())); |