diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/controller/WorkUserController.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/controller/WorkUserController.java index 6a50dc2c..8aa7b48c 100644 --- a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/controller/WorkUserController.java +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/controller/WorkUserController.java @@ -29,12 +29,22 @@ public class WorkUserController extends BaseController { LogUserUtils logUserUtils; @GetMapping("/getPage") - public TableDataInfo getPage(HttpServletRequest request) { + public TableDataInfo getPage(HttpServletRequest request, + Integer deptId, + String userName, + String loginName, + String phone, + String email) { LoginUser loginUser = logUserUtils.getLogUser(request); startPage(); Map params = new HashMap<>(); params.put("tenantId", loginUser.getTenantId()); + params.put("deptId", deptId); + params.put("userName", userName); + params.put("loginName", loginName); + params.put("phone", phone); + params.put("email", email); return getDataTable(workUserService.getPage(params)); } @@ -107,6 +117,7 @@ public class WorkUserController extends BaseController { LoginUser loginUser = logUserUtils.getLogUser(request); domain.setUpdateBy(loginUser.getUserid().toString()); + domain.setTenantId(loginUser.getTenantId()); return R.ok(workUserService.updateDomainStatus(domain)); } diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/domain/XhpcWorkUserDomain.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/domain/XhpcWorkUserDomain.java index 67d20375..7e40493d 100644 --- a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/domain/XhpcWorkUserDomain.java +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/domain/XhpcWorkUserDomain.java @@ -54,7 +54,7 @@ public class XhpcWorkUserDomain implements Serializable { /** * 状态(0-未启用,1-正常) */ - private Short status; + private Short status = 1; /** * 删除(0-正常,2-删除) @@ -100,5 +100,7 @@ public class XhpcWorkUserDomain implements Serializable { */ private Long[] roleIds; + private String roleId; + private static final long serialVersionUID = 1L; } \ No newline at end of file diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/SysUserMapper.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/SysUserMapper.java index 4bba2798..dec910e1 100644 --- a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/SysUserMapper.java +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/SysUserMapper.java @@ -8,11 +8,17 @@ public interface SysUserMapper { /** * 通过用户名查询用户 * - * @param userName 用户名 + * @param workUserId 运维用户ID * @return 用户对象信息 */ + public SysUser selectUserByWorkUserId(@Param("workUserId")String workUserId, @Param("tenantId")String tenantId); + + public SysUser selectUserByUserName(@Param("userName")String userName, @Param("tenantId")String tenantId); + + + /** * 通过用户ID查询用户 * diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/InternetBillServiceImpl.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/InternetBillServiceImpl.java index a24ae8bc..3025ceb3 100644 --- a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/InternetBillServiceImpl.java +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/InternetBillServiceImpl.java @@ -36,6 +36,7 @@ import java.io.FileInputStream; import java.math.BigDecimal; import java.nio.charset.Charset; import java.util.*; +import java.util.stream.Collectors; @Slf4j @@ -589,9 +590,10 @@ public class InternetBillServiceImpl implements InternetBillService { List orderDomainList = historyOrderMapper.findListByTimeBetween(startTime, endTime, chargingMode, tenantId); Map orderDomainMap = new HashMap<>(); - for (XhpcHistoryOrderDomain orderDomain : orderDomainList) { - orderDomainMap.put(orderDomain.getInternetSerialNumber(), orderDomain); - } +// for (XhpcHistoryOrderDomain orderDomain : orderDomainList) { +// orderDomainMap.put(orderDomain.getInternetSerialNumber(), orderDomain); +// } + orderDomainList.stream().collect(Collectors.toMap(XhpcHistoryOrderDomain:: getInternetSerialNumber, d->d)); for (XhpcTradebillInternetCheckRecordDomain domain : domainList) { XhpcHistoryOrderDomain orderDomain = orderDomainMap.get(domain.getInternetSerialNumber()); diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/WorkDeptServiceImpl.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/WorkDeptServiceImpl.java index 73dc8f2c..50053b2d 100644 --- a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/WorkDeptServiceImpl.java +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/WorkDeptServiceImpl.java @@ -42,7 +42,17 @@ public class WorkDeptServiceImpl implements WorkDeptService { for (Map dept: deptList){ params.put("parentDeptId", dept.get("id")); List> childDeptList = deptMapper.selectMapListByParams(params); - dept.put("children", childDeptList); + if(childDeptList.size() > 0){ + dept.put("children", childDeptList); + } + for (Map childMap: childDeptList){ + params.put("parentDeptId", childMap.get("id")); + List> childDeptList1 = deptMapper.selectMapListByParams(params); + if(childDeptList1.size() > 0){ + childMap.put("children", childDeptList1); + } + + } } return deptList; } diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/WorkUserServiceImpl.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/WorkUserServiceImpl.java index 9ced7bf4..16f35299 100644 --- a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/WorkUserServiceImpl.java +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/WorkUserServiceImpl.java @@ -1,6 +1,7 @@ package com.xhpc.activity.service.impl; import com.xhpc.activity.domain.SysUserRoleDomain; +import com.xhpc.activity.domain.XhpcWorkDeptDomain; import com.xhpc.activity.domain.XhpcWorkUserDomain; import com.xhpc.activity.mapper.SysUserMapper; import com.xhpc.activity.mapper.SysUserRoleMapper; @@ -8,20 +9,16 @@ import com.xhpc.activity.mapper.XhpcWorkDeptMapper; import com.xhpc.activity.mapper.XhpcWorkUserMapper; import com.xhpc.activity.service.WorkUserService; import com.xhpc.activity.vo.SysUserResetPasswordVo; -import com.xhpc.common.core.constant.UserConstants; import com.xhpc.common.core.exception.CustomException; import com.xhpc.common.core.utils.SecurityUtils; import com.xhpc.common.core.utils.StringUtils; -import com.xhpc.common.core.web.domain.AjaxResult; import com.xhpc.system.api.domain.SysUser; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; -import java.util.ArrayList; -import java.util.Date; -import java.util.List; -import java.util.Map; +import java.util.*; +import java.util.stream.Collectors; @Service @@ -61,8 +58,8 @@ public class WorkUserServiceImpl implements WorkUserService { public List> getDeptAndUserByMap(Map params){ List> deptDomains = deptMapper.selectMapListByParams(params); for(Map deptMap: deptDomains){ - List> useres = workUserMapper.selectMapListByDeptId(deptMap.get("id").toString()); - deptMap.put("users", useres); + List> users = workUserMapper.selectMapListByDeptId(deptMap.get("id").toString()); + deptMap.put("users", users); } return deptDomains; } @@ -82,6 +79,17 @@ public class WorkUserServiceImpl implements WorkUserService { @Override public List getPage(Map params){ + Map deptParams = new HashMap<>(); + deptParams.put("tenantId", params.get("tenantId")); + + String deptIds = params.get("deptId") + ""; + for(int i=0; i< 3;i++){ + deptParams.put("parentDeptIds", params.get("deptId")); + List deptDomainList = deptMapper.selectListByParams(deptParams); + deptIds = deptDomainList.stream().map(dept->dept.getWorkDeptId().toString()).collect(Collectors.joining(",")); + } + + params.put("deptIds", deptIds); return workUserMapper.selectPage(params); } @@ -152,33 +160,16 @@ public class WorkUserServiceImpl implements WorkUserService { workUserMapper.updateByPrimaryKey(domain); userMapper.updateUser(user); - // 删除用户与角色关联 - roleMapper.deleteUserRoleByUserId(user.getUserId()); - - Long[] roles = domain.getRoleIds(); - if (StringUtils.isNotNull(roles)) - { - // 新增用户与角色管理 - List list = new ArrayList(); - for (Long roleId : roles) - { - SysUserRoleDomain ur = new SysUserRoleDomain(); - ur.setUserId(user.getUserId()); - ur.setRoleId(roleId); - list.add(ur); - } - if (list.size() > 0) - { - roleMapper.batchUserRole(list); - } - } return true; } @Override public Boolean updateDomainStatus(XhpcWorkUserDomain domain){ - SysUser user = userMapper.selectUserByUserName(domain.getLoginName(), domain.getTenantId()); + SysUser user = userMapper.selectUserByWorkUserId(domain.getWorkUserId().toString(), domain.getTenantId()); + if(StringUtils.isNull(user)){ + throw new CustomException("系统用户不存在"); + } switch (domain.getStatus()){ case 0: user.setStatus("1"); break; @@ -225,8 +216,11 @@ public class WorkUserServiceImpl implements WorkUserService { user.setEmail(domain.getEmail()); user.setPhonenumber(domain.getPhone()); user.setDataPowerType(0); - user.setStatus(domain.getStatus().toString()); - + switch (domain.getStatus()){ + case 0: user.setStatus("1"); break; + case 1: user.setStatus("0"); break; + default: user.setStatus("0");break; + } user.setAvatar("https://xhpc-bucket1.oss-cn-hangzhou.aliyuncs.com/avatar/logo.png"); user.setCreateBy(SecurityUtils.getUsername()); user.setPassword(SecurityUtils.encryptPassword(domain.getLoginPassword())); diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/vo/SysUserResetPasswordVo.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/vo/SysUserResetPasswordVo.java index 8dd66eef..976e0654 100644 --- a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/vo/SysUserResetPasswordVo.java +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/vo/SysUserResetPasswordVo.java @@ -6,6 +6,6 @@ import lombok.Data; @Data public class SysUserResetPasswordVo { private String loginName; - private String password; + private String password = "123456"; private String tenantId; } diff --git a/xhpc-modules/xhpc-activity/src/main/resources/mapper/SysUserMapper.xml b/xhpc-modules/xhpc-activity/src/main/resources/mapper/SysUserMapper.xml index 6533ccd0..6f5b8dc8 100644 --- a/xhpc-modules/xhpc-activity/src/main/resources/mapper/SysUserMapper.xml +++ b/xhpc-modules/xhpc-activity/src/main/resources/mapper/SysUserMapper.xml @@ -95,11 +95,18 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" + + + diff --git a/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcWorkUserMapper.xml b/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcWorkUserMapper.xml index e2fcc31e..25e37e67 100644 --- a/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcWorkUserMapper.xml +++ b/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcWorkUserMapper.xml @@ -51,10 +51,13 @@ - select - + , su.user_name as 'login_name', GROUP_CONCAT(r.role_id) as 'role_id', "123456" as 'login_password' from xhpc_work_user u + left join sys_user su on su.phonenumber = u.phone + left join sys_user_role r on r.user_id=su.user_id where u.work_user_id = #{workUserId,jdbcType=BIGINT} @@ -106,12 +109,13 @@