package cn.iocoder.yudao.module.mes.service.wm.packages;
|
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.util.ObjUtil;
|
import cn.iocoder.yudao.framework.common.pojo.PageResult;
|
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
|
import cn.iocoder.yudao.module.crm.api.customer.CrmCustomerApi;
|
import cn.iocoder.yudao.module.mes.controller.admin.wm.packages.vo.MesWmPackagePageReqVO;
|
import cn.iocoder.yudao.module.mes.controller.admin.wm.packages.vo.MesWmPackageSaveReqVO;
|
import cn.iocoder.yudao.module.mes.dal.dataobject.wm.packages.MesWmPackageDO;
|
import cn.iocoder.yudao.module.mes.dal.mysql.wm.packages.MesWmPackageMapper;
|
import cn.iocoder.yudao.module.mes.enums.wm.BarcodeBizTypeEnum;
|
import cn.iocoder.yudao.module.mes.enums.wm.MesWmPackageStatusEnum;
|
import cn.iocoder.yudao.module.mes.service.wm.barcode.MesWmBarcodeService;
|
import jakarta.annotation.Resource;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.validation.annotation.Validated;
|
|
import java.util.List;
|
import java.util.Objects;
|
|
import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
|
import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertList;
|
import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.*;
|
|
/**
|
* MES 装箱单 Service 实现类
|
*
|
* @author 芋道源码
|
*/
|
@Service
|
@Validated
|
public class MesWmPackageServiceImpl implements MesWmPackageService {
|
|
@Resource
|
private MesWmPackageMapper packageMapper;
|
|
@Resource
|
private MesWmPackageLineService packageLineService;
|
@Resource
|
private MesWmBarcodeService barcodeService;
|
@Resource
|
private CrmCustomerApi customerApi;
|
|
@Override
|
public Long createPackage(MesWmPackageSaveReqVO createReqVO) {
|
// 校验编码唯一性
|
validateCodeUnique(null, createReqVO.getCode());
|
|
// 创建装箱单，默认为草稿状态
|
MesWmPackageDO packageDO = BeanUtils.toBean(createReqVO, MesWmPackageDO.class);
|
packageDO.setStatus(MesWmPackageStatusEnum.PREPARE.getStatus())
|
.setParentId(MesWmPackageDO.PARENT_ID_ROOT);
|
packageMapper.insert(packageDO);
|
|
// 自动生成条码
|
barcodeService.autoGenerateBarcode(BarcodeBizTypeEnum.PACKAGE.getValue(),
|
packageDO.getId(), packageDO.getCode(), null);
|
return packageDO.getId();
|
}
|
|
@Override
|
public void updatePackage(MesWmPackageSaveReqVO updateReqVO) {
|
// 校验存在且为草稿
|
validatePackageExistsAndDraft(updateReqVO.getId());
|
// 校验编码唯一性
|
validateCodeUnique(updateReqVO.getId(), updateReqVO.getCode());
|
|
// 更新装箱单
|
MesWmPackageDO updateObj = BeanUtils.toBean(updateReqVO, MesWmPackageDO.class);
|
packageMapper.updateById(updateObj);
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void deletePackage(Long id) {
|
// 校验存在且为草稿
|
validatePackageExistsAndDraft(id);
|
// 如果有子箱子，不允许删除
|
List<MesWmPackageDO> children = packageMapper.selectListByParentId(id);
|
if (CollUtil.isNotEmpty(children)) {
|
throw exception(WM_PACKAGE_HAS_CHILDREN);
|
}
|
|
// 删除装箱单
|
packageMapper.deleteById(id);
|
// 删除装箱明细
|
packageLineService.deletePackageLineByPackageId(id);
|
}
|
|
@Override
|
public MesWmPackageDO getPackage(Long id) {
|
return packageMapper.selectById(id);
|
}
|
|
@Override
|
public PageResult<MesWmPackageDO> getPackagePage(MesWmPackagePageReqVO pageReqVO) {
|
List<Long> permittedClientIds = customerApi.getPermittedCustomerIds();
|
return packageMapper.selectPage(pageReqVO, permittedClientIds);
|
}
|
|
@Override
|
public void finishPackage(Long id) {
|
// 校验存在且为草稿
|
validatePackageExistsAndDraft(id);
|
|
// 更新状态为已完成
|
packageMapper.updateById(new MesWmPackageDO()
|
.setId(id).setStatus(MesWmPackageStatusEnum.FINISHED.getStatus()));
|
}
|
|
@Override
|
public void validatePackageStatusDraft(Long packageId) {
|
validatePackageExistsAndDraft(packageId);
|
}
|
|
@Override
|
public void addChildPackage(Long parentId, Long childId) {
|
// 校验父箱存在且为草稿
|
validatePackageExistsAndDraft(parentId);
|
// 校验子箱存在
|
MesWmPackageDO child = validatePackageExists(childId);
|
// 校验添加子箱的合法性
|
validateAddChildPackage(parentId, child);
|
|
// 设置子箱的 parentId
|
packageMapper.updateById(new MesWmPackageDO().setId(childId).setParentId(parentId));
|
}
|
|
@Override
|
public void removeChildPackage(Long childId) {
|
// 校验子箱存在
|
MesWmPackageDO child = validatePackageExists(childId);
|
// 校验父箱存在且为草稿
|
if (child.getParentId() != null
|
&& ObjUtil.notEqual(child.getParentId(), MesWmPackageDO.PARENT_ID_ROOT)) {
|
validatePackageExistsAndDraft(child.getParentId());
|
}
|
|
// 清除 parentId
|
packageMapper.updateById(new MesWmPackageDO().setId(childId).setParentId(MesWmPackageDO.PARENT_ID_ROOT));
|
}
|
|
@Override
|
public List<Long> getPackageAndDescendantIds(Long packageId) {
|
List<Long> result = CollUtil.newArrayList(packageId);
|
// 使用广度优先搜索 (BFS) 按层批量查询所有子孙箱 ID
|
List<Long> currentLevelIds = CollUtil.newArrayList(packageId);
|
for (int i = 0; i < Short.MAX_VALUE && CollUtil.isNotEmpty(currentLevelIds); i++) {
|
List<MesWmPackageDO> children = packageMapper.selectListByParentIds(currentLevelIds);
|
if (CollUtil.isEmpty(children)) {
|
break;
|
}
|
currentLevelIds = convertList(children, MesWmPackageDO::getId);
|
result.addAll(currentLevelIds);
|
}
|
return result;
|
}
|
|
// ========== 校验方法 ==========
|
|
private MesWmPackageDO validatePackageExists(Long id) {
|
MesWmPackageDO packageDO = packageMapper.selectById(id);
|
if (packageDO == null) {
|
throw exception(WM_PACKAGE_NOT_EXISTS);
|
}
|
return packageDO;
|
}
|
|
private MesWmPackageDO validatePackageExistsAndDraft(Long id) {
|
MesWmPackageDO packageDO = validatePackageExists(id);
|
if (ObjUtil.notEqual(MesWmPackageStatusEnum.PREPARE.getStatus(), packageDO.getStatus())) {
|
throw exception(WM_PACKAGE_STATUS_NOT_PREPARE);
|
}
|
return packageDO;
|
}
|
|
private void validateCodeUnique(Long id, String code) {
|
MesWmPackageDO packageDO = packageMapper.selectByCode(code);
|
if (packageDO == null) {
|
return;
|
}
|
if (ObjUtil.notEqual(id, packageDO.getId())) {
|
throw exception(WM_PACKAGE_CODE_DUPLICATE);
|
}
|
}
|
|
/**
|
* 校验添加子箱的合法性
|
*
|
* @param parentId 父箱 ID
|
* @param child 子箱 DO
|
*/
|
private void validateAddChildPackage(Long parentId, MesWmPackageDO child) {
|
// 1. 不能将自己作为子箱
|
if (ObjUtil.equal(parentId, child.getId())) {
|
throw exception(WM_PACKAGE_PARENT_SELF);
|
}
|
// 2. 子箱没有父箱（parentId 为 0）
|
if (ObjUtil.notEqual(child.getParentId(), MesWmPackageDO.PARENT_ID_ROOT)) {
|
throw exception(WM_PACKAGE_CHILD_HAS_PARENT);
|
}
|
// 3. 子箱必须是已完成状态
|
if (ObjUtil.notEqual(MesWmPackageStatusEnum.FINISHED.getStatus(), child.getStatus())) {
|
throw exception(WM_PACKAGE_CHILD_NOT_FINISHED);
|
}
|
// 4. 递归校验：确保 childId 不是 parentId 的祖先（避免形成环路）
|
MesWmPackageDO parentPackage = packageMapper.selectById(parentId);
|
for (int i = 0; i < Short.MAX_VALUE; i++) {
|
if (parentPackage == null) {
|
break;
|
}
|
// 4.1 校验环路
|
parentId = parentPackage.getParentId();
|
if (Objects.equals(child.getId(), parentId)) {
|
throw exception(WM_PACKAGE_PARENT_IS_CHILD);
|
}
|
// 4.2 继续递归下一级父箱
|
if (parentId == null || MesWmPackageDO.PARENT_ID_ROOT.equals(parentId)) {
|
break;
|
}
|
parentPackage = packageMapper.selectById(parentId);
|
}
|
}
|
|
}
|
