package com.gkhy.safePlatform.account.service.impl;
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.gkhy.safePlatform.account.entity.user.PositionInfo;
|
import com.gkhy.safePlatform.account.entity.user.PositionInfoDO;
|
import com.gkhy.safePlatform.account.enums.PositionStatusEnum;
|
import com.gkhy.safePlatform.account.model.dto.req.PositionAddReqDTO;
|
import com.gkhy.safePlatform.account.model.dto.req.PositionModReqDTO;
|
import com.gkhy.safePlatform.account.model.dto.resp.PositionDetailRespDTO;
|
import com.gkhy.safePlatform.account.model.dto.resp.PositionRespDTO;
|
import com.gkhy.safePlatform.account.model.query.PositionPageQuery;
|
import com.gkhy.safePlatform.account.model.query.PositionQuery;
|
import com.gkhy.safePlatform.account.model.query.db.PositionDBQuery;
|
import com.gkhy.safePlatform.account.model.query.db.PositionPageDBQuery;
|
import com.gkhy.safePlatform.account.service.PositionService;
|
import com.gkhy.safePlatform.account.service.baseService.PositionInfoService;
|
import com.gkhy.safePlatform.account.service.baseService.UserInfoService;
|
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.SearchResultVO;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import javax.swing.text.Position;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
@Service("positionService")
|
public class PositionServiceImpl implements PositionService {
|
|
@Autowired
|
private PositionInfoService positionInfoService;
|
@Autowired
|
private UserInfoService userInfoService;
|
|
|
@Override
|
public List<PositionRespDTO> listPositionInfo(ContextCacheUser currentUser, PositionQuery query) {
|
;
|
PositionDBQuery dbQuery = new PositionDBQuery();
|
dbQuery.setPositionCode(query.getPositionCode());
|
dbQuery.setPositionName(query.getPositionName());
|
List<PositionInfoDO> dos = positionInfoService.listPositionInfo(dbQuery);
|
|
List<PositionRespDTO> respDTOList = new ArrayList<>(dos.size());
|
PositionRespDTO respDTO;
|
for (PositionInfoDO positionInfoDO : dos) {
|
respDTO = new PositionRespDTO();
|
respDTO.setPositionId(positionInfoDO.getId());
|
respDTO.setPositionCode(positionInfoDO.getCode());
|
respDTO.setPositionName(positionInfoDO.getName());
|
respDTO.setStatus(positionInfoDO.getStatus());
|
PositionStatusEnum positionStatusEnum = PositionStatusEnum.parse(positionInfoDO.getStatus());
|
if (positionStatusEnum != null) {
|
respDTO.setStatusDesc(positionStatusEnum.getValue());
|
}
|
respDTOList.add(respDTO);
|
}
|
return respDTOList;
|
}
|
|
@Override
|
public SearchResultVO<List<PositionDetailRespDTO>> listPositionInfoByPage(ContextCacheUser currentUser, PageQuery<PositionQuery> pageQuery) {
|
;
|
Page<PositionInfo> page = new Page<>(pageQuery.getPageIndex(), pageQuery.getPageSize());
|
PositionPageDBQuery dbQuery = new PositionPageDBQuery();
|
if (pageQuery.getSearchParams() != null) {
|
dbQuery.setPositionCode(pageQuery.getSearchParams().getPositionCode());
|
dbQuery.setPositionName(pageQuery.getSearchParams().getPositionName());
|
|
}
|
List<PositionInfo> dos = positionInfoService.listPositionInfoByPage(page, dbQuery);
|
List<PositionDetailRespDTO> respDTOList = new ArrayList<>(dos.size());
|
if (dos.size() > 0) {
|
PositionDetailRespDTO respDTO;
|
for (PositionInfo positionInfo : dos) {
|
respDTO = new PositionDetailRespDTO();
|
respDTO.setPositionId(positionInfo.getId());
|
respDTO.setPositionCode(positionInfo.getCode());
|
respDTO.setPositionName(positionInfo.getName());
|
respDTO.setGmtCreate(positionInfo.getGmtCreate());
|
respDTO.setCreateBy(positionInfo.getCreateBy());
|
respDTO.setGmtModified(positionInfo.getGmtModified());
|
respDTO.setEditBy(positionInfo.getEditBy());
|
respDTO.setStatus(positionInfo.getStatus());
|
PositionStatusEnum positionStatusEnum = PositionStatusEnum.parse(positionInfo.getStatus());
|
if (positionStatusEnum != null) {
|
respDTO.setStatusDesc(positionStatusEnum.getValue());
|
}
|
respDTOList.add(respDTO);
|
}
|
}
|
return new SearchResultVO<>(
|
true,
|
page.getCurrent(),
|
page.getSize(),
|
page.getPages(),
|
page.getTotal(),
|
respDTOList,
|
ResultCodes.OK);
|
}
|
|
|
@Override
|
public void addPositionInfo(ContextCacheUser currentUser, PositionAddReqDTO positionAddReqDTO) {
|
;
|
if (StringUtils.isBlank(positionAddReqDTO.getPositionCode())) {
|
throw new AusinessException(E.DATA_PARAM_NULL, "岗位编码为空");
|
}
|
if (StringUtils.isBlank(positionAddReqDTO.getPositionName())) {
|
throw new AusinessException(E.DATA_PARAM_NULL, "岗位名称为空");
|
}
|
String code = positionAddReqDTO.getPositionCode().trim();
|
String name = positionAddReqDTO.getPositionName().trim();
|
// code 判重
|
PositionInfo positionInfo;
|
positionInfo = positionInfoService.getPositionInfoByCode(code);
|
if (positionInfo != null) {
|
throw new AusinessException(E.DATA_DATABASE_EXIST, "岗位编码已存在");
|
}
|
// name 判重
|
|
positionInfo = positionInfoService.getPositionInfoByName(name);
|
if (positionInfo != null) {
|
throw new AusinessException(E.DATA_DATABASE_EXIST, "岗位名称已存在");
|
}
|
|
// 1.新增
|
positionInfo = new PositionInfo();
|
positionInfo.setCode(code);
|
positionInfo.setName(name);
|
positionInfo.setCreateBy(currentUser.getRealName());
|
positionInfo.setCreateUid(currentUser.getUid());
|
positionInfo.setGmtCreate(new Date());
|
positionInfo.setStatus(PositionStatusEnum.ENABLED.getCode());
|
positionInfoService.savePositionInfo(positionInfo);
|
}
|
|
@Override
|
public void modPositionInfo(ContextCacheUser currentUser, PositionModReqDTO positionModReqDTO) {
|
;
|
// 数据判空
|
if (positionModReqDTO.getPositionId() == null) {
|
throw new BusinessException(ResultCodes.CLIENT_PARAM_NULL);
|
}
|
if (StringUtils.isBlank(positionModReqDTO.getPositionCode())) {
|
throw new AusinessException(E.DATA_PARAM_NULL, "岗位编码为空");
|
}
|
if (StringUtils.isBlank(positionModReqDTO.getPositionName())) {
|
throw new AusinessException(E.DATA_PARAM_NULL, "岗位名称为空");
|
}
|
String code = positionModReqDTO.getPositionCode().trim();
|
String name = positionModReqDTO.getPositionName().trim();
|
// 数据存在校验
|
PositionInfoDO positionInfoDO = positionInfoService.getPositionInfoById(positionModReqDTO.getPositionId());
|
if (positionInfoDO == null) {
|
throw new AusinessException(E.DATA_DATABASE_NO_EXISTENT, "岗位记录不存在");
|
}
|
if (!positionInfoDO.getStatus().equals(PositionStatusEnum.ENABLED.getCode())) {
|
throw new AusinessException(E.DATA_DATABASE_EXIST_BUT_NOT_VALID, "岗位记录不存在");
|
}
|
PositionInfo positionInfo;
|
// 岗位编码判重
|
positionInfo = positionInfoService.getPositionInfoByCode(code);
|
if (positionInfo != null && !positionInfo.getId().equals(positionInfoDO.getId())) {
|
throw new AusinessException(E.DATA_DATABASE_EXIST, "岗位编码已存在");
|
}
|
// 岗位名称判重
|
positionInfo = positionInfoService.getPositionInfoByName(name);
|
if (positionInfo != null && !positionInfo.getId().equals(positionInfoDO.getId())) {
|
throw new AusinessException(E.DATA_DATABASE_EXIST, "岗位名称已存在");
|
}
|
// 1.更新
|
positionInfo = new PositionInfo();
|
positionInfo.setId(positionInfoDO.getId());
|
positionInfo.setCode(positionModReqDTO.getPositionCode());
|
positionInfo.setName(positionModReqDTO.getPositionName());
|
positionInfo.setGmtModified(new Date());
|
positionInfo.setEditUid(currentUser.getUid());
|
positionInfo.setEditBy(currentUser.getRealName());
|
positionInfoService.updatePositionInfo(positionInfo);
|
}
|
|
@Override
|
public void delPositionInfo(ContextCacheUser currentUser, Long positionId) {
|
;
|
if (positionId == null) {
|
throw new BusinessException(ResultCodes.CLIENT_PARAM_NULL);
|
}
|
// 数据存在校验
|
PositionInfoDO positionInfoDO = positionInfoService.getPositionInfoById(positionId);
|
if (positionInfoDO == null) {
|
throw new AusinessException(E.DATA_DATABASE_NO_EXISTENT, "岗位记录不存在");
|
}
|
if (!positionInfoDO.getStatus().equals(PositionStatusEnum.ENABLED.getCode())) {
|
throw new AusinessException(E.DATA_DATABASE_EXIST_BUT_NOT_VALID, "岗位记录不存在");
|
}
|
// 判断是否有人员占用岗位，占用不可删除
|
long count = userInfoService.countByPositionId(positionId);
|
if (count > 0) {
|
throw new AusinessException(E.NOT_DELETE, "岗位下存在人员");
|
}
|
// 删除岗位
|
positionInfoService.deletePositionInfoById(positionId);
|
|
}
|
|
|
}
|
