Commit a614038d by 邹磊浩

修改代码

parent d79e7805
...@@ -12,6 +12,7 @@ import com.pz.common.core.domain.model.SmsLoginBody; ...@@ -12,6 +12,7 @@ import com.pz.common.core.domain.model.SmsLoginBody;
import com.pz.common.helper.LoginHelper; import com.pz.common.helper.LoginHelper;
import com.pz.system.domain.vo.RouterVo; import com.pz.system.domain.vo.RouterVo;
import com.pz.system.service.ISysMenuService; import com.pz.system.service.ISysMenuService;
import com.pz.system.service.ISysRoleService;
import com.pz.system.service.ISysUserService; import com.pz.system.service.ISysUserService;
import com.pz.system.service.SysLoginService; import com.pz.system.service.SysLoginService;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
...@@ -39,6 +40,7 @@ public class SysLoginController { ...@@ -39,6 +40,7 @@ public class SysLoginController {
private final SysLoginService loginService; private final SysLoginService loginService;
private final ISysMenuService menuService; private final ISysMenuService menuService;
private final ISysUserService userService; private final ISysUserService userService;
private final ISysRoleService iSysRoleService;
/** /**
* 登录方法 * 登录方法
...@@ -108,6 +110,7 @@ public class SysLoginController { ...@@ -108,6 +110,7 @@ public class SysLoginController {
public R<Map<String, Object>> getInfo() { public R<Map<String, Object>> getInfo() {
LoginUser loginUser = LoginHelper.getLoginUser(); LoginUser loginUser = LoginHelper.getLoginUser();
SysUser user = userService.selectUserById(loginUser.getUserId()); SysUser user = userService.selectUserById(loginUser.getUserId());
user.setRoleId(iSysRoleService.getRoleByUserId(user.getUserId()).getRoleId());
Map<String, Object> ajax = new HashMap<>(); Map<String, Object> ajax = new HashMap<>();
ajax.put("user", user); ajax.put("user", user);
ajax.put("roles", loginUser.getRolePermission()); ajax.put("roles", loginUser.getRolePermission());
......
...@@ -106,7 +106,7 @@ spring: ...@@ -106,7 +106,7 @@ spring:
# 端口,默认为6379 # 端口,默认为6379
port: 6319 port: 6319
# 数据库索引 # 数据库索引
database: 0 database: 3
# 密码(如没有密码请注释掉) # 密码(如没有密码请注释掉)
password: yongqi@2022 password: yongqi@2022
# 连接超时时间 # 连接超时时间
......
...@@ -42,6 +42,8 @@ public interface SysRoleMapper extends BaseMapperPlus<SysRoleMapper, SysRole, Sy ...@@ -42,6 +42,8 @@ public interface SysRoleMapper extends BaseMapperPlus<SysRoleMapper, SysRole, Sy
*/ */
List<SysRole> selectRolePermissionByUserId(Long userId); List<SysRole> selectRolePermissionByUserId(Long userId);
SysRole getRoleByUserId(@Param("userId")Long userId);
/** /**
* 根据用户ID获取角色选择框列表 * 根据用户ID获取角色选择框列表
......
...@@ -73,7 +73,7 @@ public interface TotalOrderMapper extends BaseMapperPlus<TotalOrderMapper, Total ...@@ -73,7 +73,7 @@ public interface TotalOrderMapper extends BaseMapperPlus<TotalOrderMapper, Total
* @param time * @param time
* @return * @return
*/ */
List<OrderColumnarVo> findOrderColumnarVoList(@Param("time") String time,@Param("emIds")List<Integer> emIdS); List<OrderColumnarVo> findOrderColumnarVoList(@Param("time") String time,@Param("emIds")List<Integer> emIds);
List<OrderColumnarVo> findStoreOrderVoList(@Param("time")String time,@Param("emIds")List<Integer> emIdS); OrderColumnarVo findStoreOrderVoList(@Param("time")String time,@Param("emIds")List<Integer> emIdS);
} }
...@@ -34,6 +34,8 @@ public interface ISysRoleService { ...@@ -34,6 +34,8 @@ public interface ISysRoleService {
*/ */
List<SysRole> selectRolesByUserId(Long userId); List<SysRole> selectRolesByUserId(Long userId);
SysRole getRoleByUserId(Long userId);
/** /**
* 根据用户ID查询角色权限 * 根据用户ID查询角色权限
* *
......
...@@ -13,6 +13,7 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers; ...@@ -13,6 +13,7 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.pz.common.constant.CacheConstants; import com.pz.common.constant.CacheConstants;
import com.pz.common.constant.Constants; import com.pz.common.constant.Constants;
import com.pz.common.core.domain.dto.RoleDTO; import com.pz.common.core.domain.dto.RoleDTO;
import com.pz.common.core.domain.entity.SysRole;
import com.pz.common.core.domain.entity.SysUser; import com.pz.common.core.domain.entity.SysUser;
import com.pz.common.core.domain.event.LogininforEvent; import com.pz.common.core.domain.event.LogininforEvent;
import com.pz.common.core.domain.model.LoginUser; import com.pz.common.core.domain.model.LoginUser;
...@@ -90,19 +91,18 @@ public class SysLoginService { ...@@ -90,19 +91,18 @@ public class SysLoginService {
// 框架登录不限制从什么表查询 只要最终构建出 LoginUser 即可 // 框架登录不限制从什么表查询 只要最终构建出 LoginUser 即可
SysUser user = loadUserByUsername(username); SysUser user = loadUserByUsername(username);
checkLogin(LoginType.PASSWORD, username, () -> !BCrypt.checkpw(password, user.getPassword())); checkLogin(LoginType.PASSWORD, username, () -> !BCrypt.checkpw(password, user.getPassword()));
SysRole role = iSysRoleService.getRoleByUserId(user.getUserId());
Optional.ofNullable(iSysRoleService.selectRolesByUserId(user.getUserId())).ifPresent(sysRoles -> { Optional.ofNullable(role).ifPresent(sysRoles -> {
if (sysRoles.get(0).getRoleId().equals(3)) { user.setRoleId(role.getRoleId());
if (role.getRoleId().equals(3)) {
Optional.ofNullable(companyMapper.selectOne(Wrappers.<Company>lambdaQuery().eq(Company::getUid, user.getUserId()).eq(Company::getStatus, 1))) Optional.ofNullable(companyMapper.selectOne(Wrappers.<Company>lambdaQuery().eq(Company::getUid, user.getUserId()).eq(Company::getStatus, 1)))
.orElseThrow(() -> new ServiceException("审核暂未通过,请等待!")); .orElseThrow(() -> new ServiceException("审核暂未通过,请等待!"));
} }
}); });
// 此处可根据登录用户的数据不同 自行创建 loginUser 属性不够用继承扩展就行了 // 此处可根据登录用户的数据不同 自行创建 loginUser 属性不够用继承扩展就行了
LoginUser loginUser = buildLoginUser(user); LoginUser loginUser = buildLoginUser(user);
// 生成token // 生成token
LoginHelper.loginByDevice(loginUser, DeviceType.PC); LoginHelper.loginByDevice(loginUser, DeviceType.PC);
recordLogininfor(username, Constants.LOGIN_SUCCESS, MessageUtils.message("user.login.success")); recordLogininfor(username, Constants.LOGIN_SUCCESS, MessageUtils.message("user.login.success"));
recordLoginInfo(user.getUserId(), username); recordLoginInfo(user.getUserId(), username);
return StpUtil.getTokenValue(); return StpUtil.getTokenValue();
...@@ -361,6 +361,7 @@ public class SysLoginService { ...@@ -361,6 +361,7 @@ public class SysLoginService {
loginUser.setMenuPermission(permissionService.getMenuPermission(user)); loginUser.setMenuPermission(permissionService.getMenuPermission(user));
loginUser.setRolePermission(permissionService.getRolePermission(user)); loginUser.setRolePermission(permissionService.getRolePermission(user));
loginUser.setDeptName(ObjectUtil.isNull(user.getDept()) ? "" : user.getDept().getDeptName()); loginUser.setDeptName(ObjectUtil.isNull(user.getDept()) ? "" : user.getDept().getDeptName());
loginUser.setRoleId(user.getRoleId());
List<RoleDTO> roles = BeanUtil.copyToList(user.getRoles(), RoleDTO.class); List<RoleDTO> roles = BeanUtil.copyToList(user.getRoles(), RoleDTO.class);
loginUser.setRoles(roles); loginUser.setRoles(roles);
return loginUser; return loginUser;
......
...@@ -98,6 +98,11 @@ public class SysRoleServiceImpl implements ISysRoleService { ...@@ -98,6 +98,11 @@ public class SysRoleServiceImpl implements ISysRoleService {
return roles; return roles;
} }
@Override
public SysRole getRoleByUserId(Long userId) {
return baseMapper.getRoleByUserId(userId);
}
/** /**
* 根据用户ID查询权限 * 根据用户ID查询权限
* *
......
...@@ -1248,12 +1248,14 @@ public class TotalOrderServiceImpl implements ITotalOrderService { ...@@ -1248,12 +1248,14 @@ public class TotalOrderServiceImpl implements ITotalOrderService {
//商户 //商户
if (roleId == 3L) { if (roleId == 3L) {
//查找该商户 //查找该商户
Optional.ofNullable(companyMapper.selectOne(Wrappers.<Company>lambdaQuery().eq(Company::getUid, userId).eq(Company::getStatus, 2))) Optional.ofNullable(companyMapper.selectOne(Wrappers.<Company>lambdaQuery().eq(Company::getUid, userId).eq(Company::getStatus, 1)))
.ifPresent(company -> { .ifPresent(company -> {
//获取该商户下所有陪诊员 //获取该商户下所有陪诊员
List<Employees> employees = employeesMapper.selectList(Wrappers.<Employees>lambdaQuery().eq(Employees::getCompanyId, company.getId())); List<Employees> employees = employeesMapper.selectList(Wrappers.<Employees>lambdaQuery().eq(Employees::getCompanyId, company.getId()));
if (CollectionUtils.isNotEmpty(employees)) { if (CollectionUtils.isNotEmpty(employees)) {
bo.setEmIds(employees.stream().map(Employees::getId).collect(Collectors.toList())); bo.setEmIds(employees.stream().map(Employees::getId).collect(Collectors.toList()));
} else {
bo.setEmIds(Arrays.asList(999999));
} }
}); });
} }
...@@ -1277,12 +1279,15 @@ public class TotalOrderServiceImpl implements ITotalOrderService { ...@@ -1277,12 +1279,15 @@ public class TotalOrderServiceImpl implements ITotalOrderService {
for (String time : recentDates) { for (String time : recentDates) {
List<OrderColumnarVo> orderColumnarVoList = orderMap.get(time); List<OrderColumnarVo> orderColumnarVoList = orderMap.get(time);
if (orderColumnarVoList == null) { if (orderColumnarVoList == null) {
orderColumnarVoList = baseMapper.findOrderColumnarVoList(time,bo.getEmIds()); orderColumnarVoList = baseMapper.findOrderColumnarVoList(time, bo.getEmIds());
OrderColumnarVo orderColumnarVo = baseMapper.findStoreOrderVoList(time, bo.getEmIds());
orderColumnarVoList.add(orderColumnarVo);
orderMap.put(time, orderColumnarVoList); orderMap.put(time, orderColumnarVoList);
} }
OrderLineVo orderLineVo = new OrderLineVo(); OrderLineVo orderLineVo = new OrderLineVo();
orderLineVo.setKey(time); orderLineVo.setKey(time);
orderLineVo.setList(orderColumnarVoList); orderLineVo.setList(orderColumnarVoList);
list.add(orderLineVo); list.add(orderLineVo);
} }
......
...@@ -66,5 +66,11 @@ ...@@ -66,5 +66,11 @@
<include refid="selectRoleVo"/> <include refid="selectRoleVo"/>
WHERE r.del_flag = '0' and u.user_name = #{userName} WHERE r.del_flag = '0' and u.user_name = #{userName}
</select> </select>
<select id="getRoleByUserId" resultType="com.pz.common.core.domain.entity.SysRole"
parameterType="java.lang.Long">
select r.*
from sys_role r
left join sys_user_role sur on sur.role_id = r.role_id
where sur.user_id = #{userId}
</select>
</mapper> </mapper>
...@@ -134,7 +134,7 @@ ...@@ -134,7 +134,7 @@
AND t.`status` = 2 AND t.`status` = 2
AND DATE (t.create_time) = DATE (#{time}) AND DATE (t.create_time) = DATE (#{time})
<if test="emIds != null and emIds.size() > 0"> <if test="emIds != null and emIds.size() > 0">
AND t.em_id IN(emIds) AND t.em_id IN(#{emIds})
</if> </if>
GROUP BY b.id; GROUP BY b.id;
</select> </select>
...@@ -143,7 +143,7 @@ ...@@ -143,7 +143,7 @@
WHERE business_id = 0 AND `status` = 2 WHERE business_id = 0 AND `status` = 2
AND DATE (create_time) = DATE (#{time}) AND DATE (create_time) = DATE (#{time})
<if test="emIds != null and emIds.size() > 0"> <if test="emIds != null and emIds.size() > 0">
AND em_id IN(emIds) AND em_id IN(#{emIds})
</if> </if>
</select> </select>
<select id="selectPlatformCom" resultType="com.pz.system.domain.vo.DataOrderVo"> <select id="selectPlatformCom" resultType="com.pz.system.domain.vo.DataOrderVo">
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment