package cn.iocoder.yudao.module.crm.service.contract;
|
|
import cn.hutool.core.util.StrUtil;
|
import cn.iocoder.yudao.framework.common.pojo.PageResult;
|
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
|
import cn.iocoder.yudao.module.crm.controller.admin.contract.vo.command.CrmContractCommandPageReqVO;
|
import cn.iocoder.yudao.module.crm.controller.admin.contract.vo.command.CrmContractCommandRespVO;
|
import cn.iocoder.yudao.module.crm.controller.admin.contract.vo.command.CrmContractCommandSaveReqVO;
|
import cn.iocoder.yudao.module.crm.dal.dataobject.contract.CrmContractCommandDO;
|
import cn.iocoder.yudao.module.crm.dal.dataobject.contract.CrmContractDO;
|
import cn.iocoder.yudao.module.crm.dal.mysql.contract.CrmContractCommandMapper;
|
import cn.iocoder.yudao.module.crm.dal.mysql.contract.CrmContractMapper;
|
import cn.iocoder.yudao.module.crm.enums.ErrorCodeConstants;
|
import cn.iocoder.yudao.module.mes.api.workorder.MesProWorkOrderApi;
|
import jakarta.annotation.Resource;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.validation.annotation.Validated;
|
|
import java.time.LocalDateTime;
|
import java.util.List;
|
|
import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
|
|
@Service
|
@Validated
|
public class CrmContractCommandServiceImpl implements CrmContractCommandService {
|
|
private static final Integer STATUS_WAIT = 0;
|
private static final Integer STATUS_DISPATCHED = 10;
|
private static final Integer STATUS_DONE = 20;
|
private static final Integer STATUS_CANCELED = 30;
|
|
/** 目标模块：MES 生产工单（有真实落地单据，执行时确认工单） */
|
private static final String TARGET_MODULE_MES_WORK_ORDER = "mes-work-order";
|
|
@Resource
|
private CrmContractCommandMapper commandMapper;
|
@Resource
|
private CrmContractMapper contractMapper;
|
@Resource
|
private MesProWorkOrderApi workOrderApi;
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public Long createCommand(CrmContractCommandSaveReqVO createReqVO) {
|
CrmContractDO contract = contractMapper.selectById(createReqVO.getContractId());
|
if (contract == null) {
|
throw exception(ErrorCodeConstants.CONTRACT_NOT_EXISTS);
|
}
|
if (StrUtil.isBlank(createReqVO.getContractNo())) {
|
createReqVO.setContractNo(contract.getNo());
|
}
|
if (createReqVO.getOperateTime() == null) {
|
createReqVO.setOperateTime(LocalDateTime.now());
|
}
|
if (createReqVO.getStatus() == null) {
|
createReqVO.setStatus(STATUS_WAIT);
|
}
|
CrmContractCommandDO entity = BeanUtils.toBean(createReqVO, CrmContractCommandDO.class);
|
commandMapper.insert(entity);
|
return entity.getId();
|
}
|
|
@Override
|
public void updateCommand(CrmContractCommandSaveReqVO updateReqVO) {
|
CrmContractCommandDO exists = commandMapper.selectById(updateReqVO.getId());
|
if (exists == null) {
|
throw exception(ErrorCodeConstants.CRM_CONTRACT_COMMAND_NOT_EXISTS);
|
}
|
CrmContractCommandDO entity = BeanUtils.toBean(updateReqVO, CrmContractCommandDO.class);
|
commandMapper.updateById(entity);
|
}
|
|
@Override
|
public void deleteCommand(Long id) {
|
CrmContractCommandDO exists = commandMapper.selectById(id);
|
if (exists == null) {
|
throw exception(ErrorCodeConstants.CRM_CONTRACT_COMMAND_NOT_EXISTS);
|
}
|
commandMapper.deleteById(id);
|
}
|
|
@Override
|
public CrmContractCommandRespVO getCommand(Long id) {
|
CrmContractCommandDO entity = commandMapper.selectById(id);
|
return entity == null ? null : BeanUtils.toBean(entity, CrmContractCommandRespVO.class);
|
}
|
|
@Override
|
public PageResult<CrmContractCommandRespVO> getCommandPage(CrmContractCommandPageReqVO pageReqVO) {
|
return BeanUtils.toBean(commandMapper.selectPage(pageReqVO), CrmContractCommandRespVO.class);
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void executeCommand(Long id) {
|
CrmContractCommandDO exists = commandMapper.selectById(id);
|
if (exists == null) {
|
throw exception(ErrorCodeConstants.CRM_CONTRACT_COMMAND_NOT_EXISTS);
|
}
|
if (!STATUS_WAIT.equals(exists.getStatus()) && !STATUS_DISPATCHED.equals(exists.getStatus())) {
|
throw exception(ErrorCodeConstants.CRM_COMMAND_EXECUTE_FAIL_STATUS);
|
}
|
// 跨模块真实下发：mes-work-order 目标模块，确认指令关联的工单
|
if (TARGET_MODULE_MES_WORK_ORDER.equals(exists.getTargetModule())) {
|
if (exists.getTargetId() == null) {
|
throw exception(ErrorCodeConstants.CRM_COMMAND_DISPATCH_TARGET_MISSING);
|
}
|
workOrderApi.confirmWorkOrder(exists.getTargetId());
|
}
|
// 其余目标模块（mes-metering/srm-service）暂无真实落地单据，仅记录状态流转
|
CrmContractCommandDO update = new CrmContractCommandDO();
|
update.setId(id);
|
update.setStatus(STATUS_DONE);
|
commandMapper.updateById(update);
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void cancelCommand(Long id) {
|
CrmContractCommandDO exists = commandMapper.selectById(id);
|
if (exists == null) {
|
throw exception(ErrorCodeConstants.CRM_CONTRACT_COMMAND_NOT_EXISTS);
|
}
|
if (!STATUS_WAIT.equals(exists.getStatus()) && !STATUS_DISPATCHED.equals(exists.getStatus())) {
|
throw exception(ErrorCodeConstants.CRM_COMMAND_EXECUTE_FAIL_STATUS);
|
}
|
// 跨模块联动取消：已下发的 MES 工单同步取消
|
if (TARGET_MODULE_MES_WORK_ORDER.equals(exists.getTargetModule())
|
&& exists.getTargetId() != null) {
|
workOrderApi.cancelWorkOrder(exists.getTargetId());
|
}
|
CrmContractCommandDO update = new CrmContractCommandDO();
|
update.setId(id);
|
update.setStatus(STATUS_CANCELED);
|
commandMapper.updateById(update);
|
}
|
|
@Override
|
public Long countByContractId(Long contractId) {
|
List<CrmContractCommandDO> list = commandMapper.selectListByContractId(contractId);
|
return (long) list.size();
|
}
|
|
}
|
