blame | history | patch | commit | commitdiff | ignore whitespace
jinpengyong
2023-10-18 cc120d54e26f64753e99b349599875cf6911a0af 
 screen-api/src/main/java/com/moral/api/service/impl/UserServiceImpl.java


@@ -30,14 +30,17 @@


import com.moral.api.entity.Group;


import com.moral.api.entity.Menu;


import com.moral.api.entity.Organization;


import com.moral.api.entity.ResponsibilityUnit;


import com.moral.api.entity.User;


import com.moral.api.entity.UserGroup;


import com.moral.api.entity.UserLog;


import com.moral.api.mapper.MenuMapper;


import com.moral.api.mapper.ResponsibilityUnitMapper;


import com.moral.api.mapper.UserGroupMapper;


import com.moral.api.mapper.UserLogMapper;


import com.moral.api.mapper.UserMapper;


import com.moral.api.pojo.bo.UserBO;


import com.moral.api.service.ResponsibilityUnitService;


import com.moral.api.service.UserService;


import com.moral.api.utils.OperationLogUtils;


import com.moral.constant.Constants;


@@ -77,12 +80,77 @@


    @Autowired


    private OperationLogUtils operationLogUtils;






    @Value("${AES.KEY}")


    private String AESKey;




    @Override


    public UserBO selectUserInfo(Map<String, Object> parameters) {


        return userMapper.selectUserInfo(parameters);


    }




    @Override


    public Map<String, Object> loginSmallRoutine(Map<String, Object> parameters) {


        UserBO userBo = selectUserInfo(parameters);


        Map<String, Object> result = new HashMap<>();


        //校验账户


        if (userBo == null) {


            result.put("code", ResponseCodeEnum.ACCOUNT_NOT_EXIST.getCode());


            result.put("msg", ResponseCodeEnum.ACCOUNT_NOT_EXIST.getMsg());


            return result;


        }


        //校验密码


        String password = parameters.get("password").toString();


        //密码解密


        password = AESUtils.decrypt(password, AESKey);


        if (!MD5Utils.saltMD5Verify(password, userBo.getPassword())) {


            result.put("code", ResponseCodeEnum.PASSWORD_INVALID.getCode());


            result.put("msg", ResponseCodeEnum.PASSWORD_INVALID.getMsg());


            return result;


        }


        //校验是否删除


        if (Constants.DELETE.equals(userBo.getIsDelete())) {


            result.put("code", ResponseCodeEnum.ACCOUNT_IS_DELETE.getCode());


            result.put("msg", ResponseCodeEnum.ACCOUNT_IS_DELETE.getMsg());


            return result;


        }


        //校验是否过期


        if (userBo.getExpireTime() != null && userBo.getExpireTime().getTime() < System.currentTimeMillis()) {


            result.put("code", ResponseCodeEnum.ACCOUNT_IS_EXPIRE.getCode());


            result.put("msg", ResponseCodeEnum.ACCOUNT_IS_EXPIRE.getMsg());


            return result;


        }


        //封装用户信息


        Map<String, Object> userInfo = new LinkedHashMap<>();


        userInfo.put("userId", userBo.getId());


        userInfo.put("account", userBo.getAccount());


        userInfo.put("userName", userBo.getUserName());


        userInfo.put("email", userBo.getEmail());


        userInfo.put("mobile", userBo.getMobile());


        userInfo.put("unitId",userBo.getUnitId());


        userInfo.put("wechat", userBo.getWechat());


        userInfo.put("expireTime", DateUtils.dateToDateString(userBo.getExpireTime()));


        userInfo.put("isAdmin", userBo.getIsAdmin());


        try {


            //生成token，并存入redis


            String token = TokenUtils.getToken(userBo.getId().toString(), userInfo);


            result.put("token", token);


        } catch (Exception e) {


            log.error("token生成异常：" + e.getMessage());


            result.put("code", ResponseCodeEnum.TOKEN_CREATE_ERROR.getCode());


            result.put("msg", ResponseCodeEnum.TOKEN_CREATE_ERROR.getMsg());


            return result;


        }


        //日志


        HttpServletRequest request = ((ServletRequestAttributes) Objects.requireNonNull(RequestContextHolder.getRequestAttributes())).getRequest();


        UserLog userLog = new UserLog();


        userLog.setType(Constants.LOGIN_OPERTATE_TYPE);


        userLog.setIp(WebUtils.getIpAddr(request));


        userLog.setOperateId(userBo.getId());


        userLog.setOrganizationId(userBo.getOrganizationId());


        userLog.setContent("登陆了用户：" + userBo.getAccount());


        userLogMapper.insert(userLog);


        return result;


    }




    @Override


@@ -119,12 +187,13 @@


        //封装用户信息


        Map<String, Object> userInfo = new LinkedHashMap<>();




        //用户in西


        //用户信息


        userInfo.put("userId", userBo.getId());


        userInfo.put("account", userBo.getAccount());


        userInfo.put("userName", userBo.getUserName());


        userInfo.put("email", userBo.getEmail());


        userInfo.put("mobile", userBo.getMobile());


        userInfo.put("unitId",userBo.getUnitId());


        userInfo.put("wechat", userBo.getWechat());


        userInfo.put("expireTime", DateUtils.dateToDateString(userBo.getExpireTime()));


        userInfo.put("isAdmin", userBo.getIsAdmin());


@@ -219,6 +288,7 @@


        //筛选出下一级菜单信息


        List<Menu> nextLevelMenus = menus.stream()


                .filter(o -> o.getParentId().equals(menu.getId()))


                .sorted(Comparator.comparing(Menu::getOrder))


                .collect(Collectors.toList());


        List<Map<String, Object>> list = new ArrayList<>();


        if (nextLevelMenus.size() > 0) {