package cn.iocoder.yudao.module.mes.service.md.workstation;
|
|
import cn.hutool.core.util.ObjUtil;
|
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
|
import cn.iocoder.yudao.module.mes.controller.admin.md.workstation.vo.worker.MesMdWorkstationWorkerSaveReqVO;
|
import cn.iocoder.yudao.module.mes.dal.dataobject.md.workstation.MesMdWorkstationWorkerDO;
|
import cn.iocoder.yudao.module.mes.dal.mysql.md.workstation.MesMdWorkstationWorkerMapper;
|
import cn.iocoder.yudao.module.system.api.dept.PostApi;
|
import jakarta.annotation.Resource;
|
import org.springframework.stereotype.Service;
|
import org.springframework.validation.annotation.Validated;
|
|
import java.util.Collections;
|
import java.util.List;
|
|
import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
|
import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.*;
|
|
/**
|
* MES 人力资源 Service 实现类
|
*
|
* @author 芋道源码
|
*/
|
@Service
|
@Validated
|
public class MesMdWorkstationWorkerServiceImpl implements MesMdWorkstationWorkerService {
|
|
@Resource
|
private MesMdWorkstationWorkerMapper workstationWorkerMapper;
|
|
@Resource
|
private PostApi postApi;
|
|
@Override
|
public Long createWorkstationWorker(MesMdWorkstationWorkerSaveReqVO createReqVO) {
|
// 校验数据
|
validateWorkstationWorkerSaveData(null, createReqVO);
|
|
// 插入
|
MesMdWorkstationWorkerDO worker = BeanUtils.toBean(createReqVO, MesMdWorkstationWorkerDO.class);
|
workstationWorkerMapper.insert(worker);
|
return worker.getId();
|
}
|
|
@Override
|
public void updateWorkstationWorker(MesMdWorkstationWorkerSaveReqVO updateReqVO) {
|
// 校验存在
|
validateWorkstationWorkerExists(updateReqVO.getId());
|
// 校验数据
|
validateWorkstationWorkerSaveData(updateReqVO.getId(), updateReqVO);
|
|
// 更新
|
MesMdWorkstationWorkerDO updateObj = BeanUtils.toBean(updateReqVO, MesMdWorkstationWorkerDO.class);
|
workstationWorkerMapper.updateById(updateObj);
|
}
|
|
private void validateWorkstationWorkerSaveData(Long id, MesMdWorkstationWorkerSaveReqVO reqVO) {
|
// 校验岗位是否存在
|
postApi.validPostList(Collections.singleton(reqVO.getPostId()));
|
// 校验同一工作站下岗位不重复（排除自身）
|
MesMdWorkstationWorkerDO existing = workstationWorkerMapper.selectByWorkstationIdAndPostId(
|
reqVO.getWorkstationId(), reqVO.getPostId());
|
if (existing != null && ObjUtil.notEqual(existing.getId(), id)) {
|
throw exception(MD_WORKSTATION_WORKER_POST_EXISTS);
|
}
|
}
|
|
@Override
|
public void deleteWorkstationWorker(Long id) {
|
// 校验存在
|
validateWorkstationWorkerExists(id);
|
|
// 删除
|
workstationWorkerMapper.deleteById(id);
|
}
|
|
private void validateWorkstationWorkerExists(Long id) {
|
if (workstationWorkerMapper.selectById(id) == null) {
|
throw exception(MD_WORKSTATION_WORKER_NOT_EXISTS);
|
}
|
}
|
|
@Override
|
public List<MesMdWorkstationWorkerDO> getWorkstationWorkerListByWorkstationId(Long workstationId) {
|
return workstationWorkerMapper.selectListByWorkstationId(workstationId);
|
}
|
|
@Override
|
public void deleteWorkstationWorkerByWorkstationId(Long workstationId) {
|
workstationWorkerMapper.deleteByWorkstationId(workstationId);
|
}
|
|
}
|
