package com.gkhy.safePlatform.account.service.impl;
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.gkhy.safePlatform.account.entity.enterprise.DepartmentInfo;
|
import com.gkhy.safePlatform.account.entity.schedule.*;
|
import com.gkhy.safePlatform.account.entity.user.UserInfo;
|
import com.gkhy.safePlatform.account.entity.user.UserInfoDO;
|
import com.gkhy.safePlatform.account.enums.DepartmentStatusEnum;
|
import com.gkhy.safePlatform.account.enums.UserStatusEnum;
|
import com.gkhy.safePlatform.account.enums.schedule.GroupStatusEnum;
|
import com.gkhy.safePlatform.account.enums.schedule.TimeTypeEnum;
|
import com.gkhy.safePlatform.account.model.bo.GroupInfoBO;
|
import com.gkhy.safePlatform.account.model.bo.GroupInfoPageBO;
|
import com.gkhy.safePlatform.account.model.dto.req.GroupAddDTO;
|
import com.gkhy.safePlatform.account.model.dto.req.GroupModDTO;
|
import com.gkhy.safePlatform.account.model.dto.resp.*;
|
import com.gkhy.safePlatform.account.model.query.GroupMemberPageQuery;
|
import com.gkhy.safePlatform.account.model.query.GroupPageQuery;
|
import com.gkhy.safePlatform.account.model.query.GroupQuery;
|
import com.gkhy.safePlatform.account.model.query.GroupScheduleQuery;
|
import com.gkhy.safePlatform.account.model.query.db.GroupDBQuery;
|
import com.gkhy.safePlatform.account.model.query.db.GroupMemberPageDBQuery;
|
import com.gkhy.safePlatform.account.model.query.db.GroupPageDBQuery;
|
import com.gkhy.safePlatform.account.model.query.db.GroupScheduleDBQuery;
|
import com.gkhy.safePlatform.account.service.GroupService;
|
import com.gkhy.safePlatform.account.service.GroupStrategyTimeTableService;
|
import com.gkhy.safePlatform.account.service.baseService.*;
|
import com.gkhy.safePlatform.account.utils.DateUtil;
|
import com.gkhy.safePlatform.commons.co.ContextCacheUser;
|
import com.gkhy.safePlatform.commons.enums.E;
|
import com.gkhy.safePlatform.commons.enums.ResultCodes;
|
import com.gkhy.safePlatform.commons.exception.AusinessException;
|
import com.gkhy.safePlatform.commons.exception.BusinessException;
|
import com.gkhy.safePlatform.commons.query.PageQuery;
|
import com.gkhy.safePlatform.commons.utils.StringUtils;
|
import com.gkhy.safePlatform.commons.vo.ResultVO;
|
import com.gkhy.safePlatform.commons.vo.SearchResultVO;
|
import com.sun.org.apache.bcel.internal.generic.IF_ACMPEQ;
|
import org.checkerframework.checker.units.qual.A;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.awt.*;
|
import java.security.acl.Group;
|
import java.time.LocalDate;
|
import java.util.*;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
@Service("groupService")
|
public class GroupServiceImpl implements GroupService {
|
|
@Autowired
|
private GroupInfoService groupInfoService;
|
@Autowired
|
private GroupMemberInfoService groupMemberInfoService;
|
@Autowired
|
private UserInfoService userInfoService;
|
@Autowired
|
private DepartmentInfoService departmentInfoService;
|
@Autowired
|
private GroupStrategyTimeTableInfoService groupStrategyTimeTableInfoService;
|
|
|
@Override
|
@Transactional
|
public void saveGroupInfo(ContextCacheUser currentUser, GroupAddDTO groupAddDTO) {
|
;
|
if (groupAddDTO.getDepId() == null) {
|
throw new BusinessException(ResultCodes.CLIENT_PARAM_NULL);
|
}
|
if (StringUtils.isBlank(groupAddDTO.getGroupName())) {
|
throw new AusinessException(E.DATA_PARAM_NULL, "班组名称不能为空");
|
}
|
String name = groupAddDTO.getGroupName().trim();
|
// 班组成员
|
List<Long> groupMemberIds = groupAddDTO.getGroupMemberIds();
|
if (groupMemberIds == null || groupMemberIds.size() < 1) {
|
throw new AusinessException(E.DATA_PARAM_NULL, "班组成员不能为空");
|
}
|
// 部门是否存在
|
DepartmentInfo department = departmentInfoService.getDepartmentInfoById(groupAddDTO.getDepId());
|
if (department == null) {
|
throw new BusinessException(ResultCodes.CLIENT_DEP_NOT_EXIST);
|
}
|
assert department.getStatus() != null;
|
if (!department.getStatus().equals(DepartmentStatusEnum.ENABLED.getCode())) {
|
throw new AusinessException(E.DATA_DATABASE_EXIST_BUT_NOT_VALID, "部门不存在");
|
}
|
|
|
// 班组成员成分判断
|
List<UserInfoDO> userInfoDOList = userInfoService.listUserByUids(groupAddDTO.getGroupMemberIds());
|
// 校验用户id
|
for (Long uid : groupAddDTO.getGroupMemberIds()) {
|
boolean flag = false;
|
for (UserInfoDO userInfoDO : userInfoDOList) {
|
// todo 可以加入用户类型type判断
|
if (userInfoDO.getUid().equals(uid)) {
|
flag = true;
|
}
|
}
|
if (!flag) {
|
throw new AusinessException(E.DATA_DATABASE_NO_EXISTENT, "用户成员不存在:" + uid);
|
}
|
}
|
// 判断用户部门是否是当前所选部门
|
for (UserInfoDO userInfoDO : userInfoDOList) {
|
if (!userInfoDO.getDepId().equals(groupAddDTO.getDepId())) {
|
throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "所选用户不在当前部门下");
|
}
|
}
|
// 校验用户所属班组都得在同一个部门下
|
List<GroupInfoDO> groupInfoDOs = groupMemberInfoService.listGroupDOByUids(groupAddDTO.getGroupMemberIds());
|
for (GroupInfoDO groupInfoDO : groupInfoDOs) {
|
if (!groupInfoDO.getDepId().equals(groupAddDTO.getDepId())) {
|
throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "数据内部错误，用户所属班组不在部门下");
|
}
|
}
|
|
// 1.班组插入
|
GroupInfo groupInfo = new GroupInfo();
|
groupInfo.setName(name);
|
groupInfo.setInfo(groupAddDTO.getGroupInfo());
|
groupInfo.setCreateBy(currentUser.getRealName());
|
groupInfo.setCreateUid(currentUser.getUid());
|
groupInfo.setGmtCreate(new Date());
|
groupInfo.setStatus(GroupStatusEnum.ENABLED.getCode());
|
groupInfo.setDepId(department.getId());
|
groupInfoService.save(groupInfo);
|
// 2.班组成员插入
|
List<GroupMemberInfo> groupMembers = new ArrayList<>();
|
GroupMemberInfo groupMemberInfo;
|
for (Long uid : groupMemberIds) {
|
groupMemberInfo = new GroupMemberInfo();
|
groupMemberInfo.setGroupId(groupInfo.getId());
|
groupMemberInfo.setUid(uid);
|
groupMembers.add(groupMemberInfo);
|
}
|
groupMemberInfoService.saveGroupMembers(groupMembers);
|
|
}
|
|
@Override
|
@Transactional
|
public void modGroupInfo(ContextCacheUser currentUser, GroupModDTO groupModDTO) {
|
if (groupModDTO.getDepId() == null) {
|
throw new BusinessException(ResultCodes.CLIENT_PARAM_NULL);
|
}
|
if (groupModDTO.getGroupId() == null) {
|
throw new BusinessException(ResultCodes.CLIENT_PARAM_NULL);
|
}
|
|
if (StringUtils.isBlank(groupModDTO.getGroupName())) {
|
throw new AusinessException(E.DATA_PARAM_NULL, "班组名称不能为空");
|
}
|
String name = groupModDTO.getGroupName().trim();
|
// 班组成员
|
List<Long> groupMemberIds = groupModDTO.getGroupMemberIds();
|
if (groupMemberIds == null || groupMemberIds.size() < 1) {
|
throw new AusinessException(E.DATA_PARAM_NULL, "班组成员不能为空");
|
}
|
// 获取班组
|
GroupInfoDO groupInfoDO = groupInfoService.getGroupInfoById(groupModDTO.getGroupId());
|
if (groupInfoDO == null ) {
|
throw new AusinessException(E.DATA_DATABASE_NO_EXISTENT, "班组不存在");
|
}
|
if (!groupInfoDO.getStatus().equals(GroupStatusEnum.ENABLED.getCode())) {
|
throw new AusinessException(E.DATA_DATABASE_EXIST_BUT_NOT_VALID, "班组不存在");
|
}
|
|
// 部门是否存在
|
DepartmentInfo department = departmentInfoService.getDepartmentInfoById(groupModDTO.getDepId());
|
if (department == null) {
|
throw new BusinessException(ResultCodes.CLIENT_DEP_NOT_EXIST);
|
}
|
assert department.getStatus() != null;
|
if (!department.getStatus().equals(DepartmentStatusEnum.ENABLED.getCode())) {
|
throw new AusinessException(E.DATA_DATABASE_EXIST_BUT_NOT_VALID, "部门不存在");
|
}
|
|
// 1.获取绑定人员
|
List<Long> groupMembersIdsOrigin = groupMemberInfoService.getGroupMembersIdsByGroupId(groupInfoDO.getId());
|
// original - now
|
List<Long> toDelMemberIds = groupMembersIdsOrigin.stream()
|
// 不包含
|
.filter(id -> !groupModDTO.getGroupMemberIds().contains(id))
|
// 集合
|
.collect(Collectors.toList());
|
// now - original
|
List<Long> toAddMemberIds = groupModDTO.getGroupMemberIds().stream()
|
// 不包含
|
.filter(id -> !groupMembersIdsOrigin.contains(id))
|
// 集合
|
.collect(Collectors.toList());
|
// 2.新增人员成分判断
|
List<Long> toOperateIds = new ArrayList<>(toAddMemberIds.size() + toDelMemberIds.size());
|
toOperateIds.addAll(toAddMemberIds);
|
toOperateIds.addAll(toDelMemberIds);
|
List<UserInfoDO> userInfoDOs= userInfoService.listUserByUids(toOperateIds);
|
|
// 3.uid校验
|
for (Long uid : toOperateIds) {
|
boolean flag = false;
|
for (UserInfoDO userInfoDO : userInfoDOs) {
|
if (userInfoDO.getUid().equals(uid)) {
|
flag = true;
|
}
|
}
|
if (!flag) {
|
throw new AusinessException(E.DATA_DATABASE_NO_EXISTENT, "用户成员不存在:" + uid);
|
}
|
}
|
|
// 4.用户部门的校验
|
for (UserInfoDO userInfoDO : userInfoDOs) {
|
if (!userInfoDO.getDepId().equals(groupModDTO.getDepId())) {
|
throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "所选用户不在当前部门下:" + userInfoDO.getUid());
|
}
|
}
|
// 校验用户所属班组都得在同一个部门下
|
List<GroupInfoDO> groupInfoDOs = groupMemberInfoService.listGroupDOByUids(groupModDTO.getGroupMemberIds());
|
for (GroupInfoDO groupInfo : groupInfoDOs) {
|
if (!groupInfo.getDepId().equals(groupModDTO.getDepId())) {
|
throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "数据内部错误，用户所属班组不在部门下");
|
}
|
}
|
|
|
// 5.更新班组
|
GroupInfo groupInfo = new GroupInfo();
|
groupInfo.setId(groupInfoDO.getId());
|
groupInfo.setName(name);
|
groupInfo.setInfo(groupInfoDO.getInfo());
|
groupInfo.setGmtModified(new Date());
|
groupInfo.setEditBy(currentUser.getRealName());
|
groupInfo.setEditUid(currentUser.getUid());
|
groupInfo.setDepId(groupModDTO.getDepId());
|
groupInfoService.updateById(groupInfo);
|
// 6.更新成员
|
// 6.1新增成员
|
if (toAddMemberIds.size() > 0) {
|
List<GroupMemberInfo> groupMembers = new ArrayList<>();
|
GroupMemberInfo groupMemberInfo;
|
for (Long uid : toAddMemberIds) {
|
groupMemberInfo = new GroupMemberInfo();
|
groupMemberInfo.setGroupId(groupInfo.getId());
|
groupMemberInfo.setUid(uid);
|
groupMembers.add(groupMemberInfo);
|
}
|
groupMemberInfoService.saveGroupMembers(groupMembers);
|
}
|
// 6.2 解绑成员
|
if (toDelMemberIds.size() > 0) {
|
groupMemberInfoService.unbindGroupMembersByUids(groupInfoDO.getId(),toDelMemberIds);
|
}
|
|
|
}
|
|
@Override
|
@Transactional
|
public void delGroupInfo(ContextCacheUser currentUser, Long groupId) {
|
;
|
if (groupId == null) {
|
throw new BusinessException(ResultCodes.CLIENT_PARAM_NULL);
|
}
|
GroupInfoDO groupInfoDO = groupInfoService.getGroupInfoById(groupId);
|
if (groupInfoDO == null) {
|
throw new AusinessException(E.DATA_DATABASE_NO_EXISTENT, "分组不存在");
|
}
|
assert groupInfoDO.getStatus() != null;
|
GroupStatusEnum status = GroupStatusEnum.parse(groupInfoDO.getStatus());
|
if (status != GroupStatusEnum.ENABLED) {
|
throw new AusinessException(E.DATA_DATABASE_EXIST_BUT_NOT_VALID, "分组不存在");
|
}
|
// 1.组成员关系解绑
|
groupMemberInfoService.unbindGroupByGroupId(groupInfoDO.getId());
|
// 2.删除分组 && 部门班组关系解绑(体现在xml中)
|
GroupInfo groupInfo = new GroupInfo();
|
groupInfo.setId(groupInfoDO.getId());
|
groupInfo.setStatus(GroupStatusEnum.ABANDONED.getCode());
|
groupInfo.setGmtModified(new Date());
|
groupInfo.setEditBy(currentUser.getRealName());
|
groupInfo.setEditUid(currentUser.getUid());
|
groupInfoService.deleteGroupInfo(groupInfo);
|
|
}
|
|
|
@Override
|
public List<GroupRespDTO> listGroupInfo(ContextCacheUser currentUser, GroupQuery query) {
|
;
|
GroupDBQuery groupDBQuery = new GroupDBQuery();
|
groupDBQuery.setDepId(query.getDepId());
|
groupDBQuery.setGroupName(query.getGroupName());
|
|
// 0.返回准备
|
List<GroupRespDTO> result = new ArrayList<>();
|
// 1.查找分组
|
List<GroupInfoBO> groups = groupInfoService.listGroupInfoBO(groupDBQuery);
|
GroupRespDTO groupRespDTO;
|
GroupStatusEnum statusEnum;
|
boolean containGroupMemberEnable = query.getContainGroupMemberEnable();
|
for (GroupInfoBO groupInfoBO : groups) {
|
groupRespDTO = new GroupRespDTO();
|
groupRespDTO.setId(groupInfoBO.getId());
|
groupRespDTO.setGroupName(groupInfoBO.getName());
|
groupRespDTO.setGroupInfo(groupInfoBO.getInfo());
|
groupRespDTO.setStatus(groupInfoBO.getStatus());
|
groupRespDTO.setGroupStrategyId(groupInfoBO.getGroupStrategyId());
|
groupRespDTO.setDepId(groupInfoBO.getDepId());
|
groupRespDTO.setDepartment(groupInfoBO.getDepartment());
|
statusEnum = GroupStatusEnum.parse(groupInfoBO.getStatus());
|
if (statusEnum != null) {
|
groupRespDTO.setStatusDesc(statusEnum.getValue());
|
}
|
|
// 2.是否包含人员
|
if (containGroupMemberEnable) {
|
List<GroupMemberInfoDO> groupMembersDO = groupMemberInfoService.getGroupMembersByGroupId(groupInfoBO.getId());
|
GroupMemberRespDTO groupMemberRespDTO;
|
List<GroupMemberRespDTO> groupMembersRespDTO = new ArrayList<>();
|
for (GroupMemberInfoDO groupMemberDO : groupMembersDO) {
|
groupMemberRespDTO = new GroupMemberRespDTO();
|
groupMemberRespDTO.setUid(groupMemberDO.getUid());
|
groupMemberRespDTO.setRealName(groupMemberDO.getRealName());
|
groupMemberRespDTO.setUsername(groupMemberDO.getUsername());
|
groupMemberRespDTO.setStatus(groupMemberDO.getStatus());
|
UserStatusEnum userStatusEnum = UserStatusEnum.parse(groupMemberDO.getStatus());
|
if (userStatusEnum != null) {
|
groupMemberRespDTO.setStatusDesc(userStatusEnum.getValue());
|
}
|
groupMembersRespDTO.add(groupMemberRespDTO);
|
}
|
groupRespDTO.setGroupMembers(groupMembersRespDTO);
|
}
|
|
result.add(groupRespDTO);
|
}
|
|
return result;
|
}
|
|
|
|
@Override
|
public GroupTimeTableRespDTO getTimeTableInfo(ContextCacheUser currentUser, GroupScheduleQuery groupScheduleQuery) {
|
;
|
if (groupScheduleQuery.getStartTime() == null || groupScheduleQuery.getEndTime() == null) {
|
throw new AusinessException(E.DATA_PARAM_NULL,"时间不能为空");
|
}
|
if (groupScheduleQuery.getStartTime().after(groupScheduleQuery.getEndTime())) {
|
throw new AusinessException(E.DATA_PARAM_CHECK_INVALID,"时间区间非法");
|
}
|
if (groupScheduleQuery.getGroupId() == null) {
|
throw new BusinessException(ResultCodes.CLIENT_PARAM_NULL);
|
}
|
GroupInfoDO groupInfo = groupInfoService.getGroupInfoById(groupScheduleQuery.getGroupId());
|
if (groupInfo == null) {
|
throw new AusinessException(E.DATA_DATABASE_NO_EXISTENT, "班组不存在");
|
}
|
if (!groupInfo.getStatus().equals(GroupStatusEnum.ENABLED.getCode())) {
|
throw new AusinessException(E.DATA_DATABASE_EXIST_BUT_NOT_VALID, "班组不存在");
|
}
|
|
|
// 查询
|
GroupScheduleDBQuery groupScheduleDBQuery = new GroupScheduleDBQuery();
|
groupScheduleDBQuery.setStartTime(groupScheduleQuery.getStartTime());
|
groupScheduleDBQuery.setEndTime(groupScheduleQuery.getEndTime());
|
groupScheduleDBQuery.setType(groupScheduleQuery.getType());
|
groupScheduleDBQuery.setGroupId(groupScheduleQuery.getGroupId());
|
List<GroupStrategyTimeTableInfoDO> groupTableTableInfos = groupStrategyTimeTableInfoService.getGroupTableTableInfo(groupScheduleDBQuery);
|
|
// 返回结果
|
GroupTimeTableRespDTO result = new GroupTimeTableRespDTO();
|
result.setGroupId(groupInfo.getId());
|
result.setGroupInfo(groupInfo.getInfo());
|
result.setGroupName(groupInfo.getName());
|
result.setDays(Collections.emptyList());
|
// 处理
|
if (groupTableTableInfos.size() > 0) {
|
// 日期池
|
Map<LocalDate, GroupTimeTableDayRespDTO> dayPool = new HashMap<>();
|
TimeTypeEnum typeEnum;
|
GroupStrategyTimeTableInfoDO timeTableInfoDO;
|
GroupTimeTableDayRespDTO day;
|
GroupTimeTableTimeDetailRespDTO timeDetail;
|
for (int i = 0; i < groupTableTableInfos.size(); i++) {
|
timeTableInfoDO = groupTableTableInfos.get(i);
|
timeDetail = new GroupTimeTableTimeDetailRespDTO();
|
timeDetail.setStartTime(timeTableInfoDO.getStartTime());
|
timeDetail.setEndTime(timeTableInfoDO.getEndTime());
|
timeDetail.setType(timeTableInfoDO.getType());
|
typeEnum = TimeTypeEnum.parse(timeTableInfoDO.getType());
|
if (typeEnum != null) {
|
timeDetail.setTypeDesc(typeEnum.getValue());
|
}
|
|
if (!dayPool.containsKey(timeTableInfoDO.getSpecificDate())) {
|
day = new GroupTimeTableDayRespDTO();
|
day.setDay(timeTableInfoDO.getSpecificDate());
|
day.setTimeDetails(Collections.singletonList(timeDetail));
|
dayPool.put(timeTableInfoDO.getSpecificDate(), day);
|
}else{
|
day = dayPool.get(timeTableInfoDO.getSpecificDate());
|
day.getTimeDetails().add(timeDetail);
|
}
|
}
|
// Map无需变有序
|
List<GroupTimeTableDayRespDTO> sortedDays = dayPool.values().stream()
|
.sorted(Comparator.comparing(GroupTimeTableDayRespDTO::getDay)).collect(Collectors.toList());
|
result.setDays(sortedDays);
|
}
|
return result;
|
|
}
|
|
|
/**
|
* @Description: rpc内部调用
|
*/
|
@Override
|
public GroupInfoRespDTO getGroupInfoByGroupId(Long groupId) {
|
if (groupId == null) {
|
throw new BusinessException(ResultCodes.SERVER_PARAM_NULL);
|
}
|
GroupInfoRespDTO respDTO = null;
|
GroupInfoDO groupInfoDO = groupInfoService.getGroupInfoById(groupId);
|
if (groupInfoDO != null) {
|
respDTO = new GroupInfoRespDTO();
|
respDTO.setGroupId(groupInfoDO.getId());
|
respDTO.setGroupName(groupInfoDO.getName());
|
respDTO.setGroupInfo(groupInfoDO.getInfo());
|
respDTO.setGroupStrategyId(groupInfoDO.getGroupStrategyId());
|
respDTO.setStatus(groupInfoDO.getStatus());
|
GroupStatusEnum groupStatusEnum = GroupStatusEnum.parse(groupInfoDO.getStatus());
|
if (groupStatusEnum != null) {
|
respDTO.setStatusDesc(groupStatusEnum.getValue());
|
}
|
}
|
return respDTO;
|
}
|
|
@Override
|
public SearchResultVO<List<GroupPageRespDTO>> listGroupInfoByPage(ContextCacheUser currentUser, PageQuery<GroupPageQuery> query) {
|
;
|
// 查询参数
|
GroupPageDBQuery dbQuery = new GroupPageDBQuery();
|
if (query.getSearchParams() != null) {
|
dbQuery.setDepId(query.getSearchParams().getDepId());
|
dbQuery.setGroupName(query.getSearchParams().getGroupName());
|
}
|
// 查询分页对象
|
Page<GroupInfo> page = new Page<>(query.getPageIndex(), query.getPageSize());
|
List<GroupInfoPageBO> dbData = groupInfoService.listGroupInfo(page, dbQuery);
|
List<GroupPageRespDTO> resPageData = new ArrayList<>(dbData.size());
|
if (dbData.size() > 0) {
|
GroupPageRespDTO respDTO;
|
for (GroupInfoPageBO groupInfo : dbData) {
|
respDTO = new GroupPageRespDTO();
|
respDTO.setGroupId(groupInfo.getId());
|
respDTO.setGroupName(groupInfo.getName());
|
respDTO.setGroupInfo(groupInfo.getInfo());
|
respDTO.setCreateBy(groupInfo.getCreateBy());
|
respDTO.setGroupStrategyId(groupInfo.getGroupStrategyId());
|
respDTO.setGmtCreate(groupInfo.getGmtCreate());
|
respDTO.setCreateBy(groupInfo.getCreateBy());
|
respDTO.setGmtModified(groupInfo.getGmtModified());
|
respDTO.setEditBy(groupInfo.getEditBy());
|
respDTO.setStatus(groupInfo.getStatus());
|
respDTO.setDepId(groupInfo.getDepId());
|
respDTO.setDepartment(groupInfo.getDepartment());
|
GroupStatusEnum groupStatusEnum = GroupStatusEnum.parse(groupInfo.getStatus());
|
if (groupStatusEnum != null) {
|
respDTO.setStatusDesc(groupStatusEnum.getValue());
|
}
|
// 成员
|
List<GroupMemberRespDTO> members = Collections.emptyList();
|
if (query.getSearchParams().isContainGroupMemberEnable()) {
|
List<GroupMemberInfoDO> groupMemberDOs = groupMemberInfoService.getGroupMembersByGroupId(groupInfo.getId());
|
members = new ArrayList<>(groupMemberDOs.size());
|
GroupMemberRespDTO memberRespDTO;
|
for (GroupMemberInfoDO groupMemberInfoDO : groupMemberDOs) {
|
memberRespDTO = new GroupMemberRespDTO();
|
memberRespDTO.setUid(groupMemberInfoDO.getUid());
|
memberRespDTO.setUsername(groupMemberInfoDO.getUsername());
|
memberRespDTO.setRealName(groupMemberInfoDO.getRealName());
|
memberRespDTO.setStatus(groupMemberInfoDO.getStatus());
|
UserStatusEnum userStatusEnum = UserStatusEnum.parse(groupMemberInfoDO.getStatus());
|
if (userStatusEnum != null) {
|
memberRespDTO.setStatusDesc(userStatusEnum.getValue());
|
}
|
members.add(memberRespDTO);
|
}
|
|
}
|
|
respDTO.setGroupMembers(members);
|
resPageData.add(respDTO);
|
}
|
}
|
return new SearchResultVO<>(
|
true,
|
page.getCurrent(),
|
page.getSize(),
|
page.getPages(),
|
page.getTotal(),
|
resPageData,
|
ResultCodes.OK);
|
}
|
|
|
@Override
|
public List<GroupMemberRespDTO> listGroupMembersByGroupId(ContextCacheUser currentUser,Long groupId) {
|
;
|
List<GroupMemberRespDTO> result = Collections.emptyList();
|
List<GroupMemberInfoDO> dbMembers = groupMemberInfoService.getGroupMembersByGroupId(groupId);
|
if (dbMembers.size() > 0) {
|
GroupMemberRespDTO member;
|
result = new ArrayList<>(dbMembers.size());
|
for (GroupMemberInfoDO groupMemberInfoDO : dbMembers) {
|
member = new GroupMemberRespDTO();
|
member.setUsername(groupMemberInfoDO.getUsername());
|
member.setRealName(groupMemberInfoDO.getRealName());
|
member.setUid(groupMemberInfoDO.getUid());
|
member.setStatus(groupMemberInfoDO.getStatus());
|
UserStatusEnum userStatusEnum = UserStatusEnum.parse(groupMemberInfoDO.getStatus());
|
if (userStatusEnum != null) {
|
member.setStatusDesc(userStatusEnum.getValue());
|
}
|
result.add(member);
|
}
|
|
}
|
return result;
|
}
|
|
|
@Override
|
public ResultVO<List<GroupMemberPageRespDTO>> listGroupMembersByPage(ContextCacheUser currentUser, PageQuery<GroupMemberPageQuery> query) {
|
;
|
GroupMemberPageDBQuery dbQuery = new GroupMemberPageDBQuery();
|
if (query.getSearchParams() != null) {
|
dbQuery.setGroupId(query.getSearchParams().getGroupId());
|
dbQuery.setRealName(query.getSearchParams().getRealName());
|
}
|
Page<GroupMemberInfoDO> page = new Page<>(query.getPageIndex(),query.getPageSize());
|
List<GroupMemberPageRespDTO> resPageData = Collections.emptyList();
|
List<GroupMemberInfoDO> dbData = groupMemberInfoService.listGroupMemberDO(page, dbQuery);
|
if (dbData.size() > 0) {
|
resPageData = new ArrayList<>(dbData.size());
|
GroupMemberPageRespDTO respDTO;
|
for (GroupMemberInfoDO groupMemberInfoDO : dbData) {
|
respDTO = new GroupMemberPageRespDTO();
|
respDTO.setUid(groupMemberInfoDO.getUid());
|
respDTO.setRealName(groupMemberInfoDO.getRealName());
|
respDTO.setUsername(groupMemberInfoDO.getUsername());
|
respDTO.setStatus(groupMemberInfoDO.getStatus());
|
UserStatusEnum userStatusEnum = UserStatusEnum.parse(groupMemberInfoDO.getStatus());
|
if (userStatusEnum != null) {
|
respDTO.setStatusDesc(userStatusEnum.getValue());
|
}
|
resPageData.add(respDTO);
|
}
|
|
}
|
return new SearchResultVO<>(
|
true,
|
page.getCurrent(),
|
page.getSize(),
|
page.getPages(),
|
page.getTotal(),
|
resPageData,ResultCodes.OK);
|
}
|
|
|
@Override
|
public List<GroupInfoRespDTO> listGroupInfoByUid(Long uid) {
|
if (uid == null) {
|
throw new BusinessException(ResultCodes.SERVER_PARAM_NULL);
|
}
|
List<GroupInfoRespDTO> result = Collections.emptyList();
|
List<GroupInfoDO> groupInfoDOs = groupMemberInfoService.listGroupInfoByUserId(uid);
|
if (groupInfoDOs.size() > 0) {
|
result = new ArrayList<>(groupInfoDOs.size());
|
GroupInfoRespDTO respDTO ;
|
for (GroupInfoDO groupInfoDO : groupInfoDOs) {
|
respDTO = new GroupInfoRespDTO();
|
respDTO.setGroupInfo(groupInfoDO.getInfo());
|
respDTO.setGroupName(groupInfoDO.getName());
|
respDTO.setGroupId(groupInfoDO.getId());
|
respDTO.setStatus(groupInfoDO.getStatus());
|
respDTO.setGroupStrategyId(groupInfoDO.getGroupStrategyId());
|
GroupStatusEnum groupStatusEnum = GroupStatusEnum.parse(groupInfoDO.getStatus());
|
if (groupStatusEnum != null) {
|
respDTO.setStatusDesc(groupStatusEnum.getValue());
|
}
|
result.add(respDTO);
|
}
|
}
|
return result;
|
}
|
|
@Override
|
public List<GroupInfoRespDTO> listGroupInfoByGroupIds(Collection<Long> groupIds) {
|
List<GroupInfoRespDTO> result = Collections.emptyList();
|
if (groupIds != null && groupIds.size() != 0) {
|
List<GroupInfoDO> groupInfoDOS = groupInfoService.listGroupDOByGroupIds(groupIds);
|
if (groupInfoDOS.size() > 0) {
|
result = new ArrayList<>(groupInfoDOS.size());
|
GroupInfoRespDTO respDTO;
|
GroupStatusEnum groupStatusEnum;
|
for (GroupInfoDO groupInfoDO : groupInfoDOS) {
|
respDTO = new GroupInfoRespDTO();
|
respDTO.setGroupId(groupInfoDO.getId());
|
respDTO.setGroupName(groupInfoDO.getName());
|
respDTO.setGroupInfo(groupInfoDO.getInfo());
|
respDTO.setStatus(groupInfoDO.getStatus());
|
groupStatusEnum = GroupStatusEnum.parse(groupInfoDO.getStatus());
|
respDTO.setStatusDesc(groupStatusEnum.getValue());
|
respDTO.setGroupStrategyId(groupInfoDO.getGroupStrategyId());
|
result.add(respDTO);
|
}
|
}
|
}
|
return result;
|
}
|
|
}
|
