package com.ruoyi.production.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.ruoyi.basic.pojo.BaseParam;
|
import com.ruoyi.basic.service.BaseParamService;
|
import com.ruoyi.common.exception.ServiceException;
|
import com.ruoyi.common.utils.SecurityUtils;
|
import com.ruoyi.production.dto.ProductionOrderRouteItemParamDto;
|
import com.ruoyi.production.mapper.ProductionOrderRouteItemParamMapper;
|
import com.ruoyi.production.pojo.ProductionOrderRouteItemParam;
|
import com.ruoyi.production.service.IProductionOrderRouteItemParamService;
|
import lombok.extern.slf4j.Slf4j;
|
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.time.LocalDateTime;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
/**
|
* <p>
|
* 生产订单绑定的工艺路线工序--参数表 服务实现类
|
* </p>
|
*
|
* @author deslrey
|
* @since 2026-03-20
|
*/
|
@Slf4j
|
@Service
|
public class ProductionOrderRouteItemParamServiceImpl extends ServiceImpl<ProductionOrderRouteItemParamMapper, ProductionOrderRouteItemParam> implements IProductionOrderRouteItemParamService {
|
|
@Autowired
|
private BaseParamService baseParamService;
|
|
@Override
|
public List<ProductionOrderRouteItemParamDto> routeItemParamList(Long orderId, Long routeItemId) {
|
List<ProductionOrderRouteItemParam> list = list(new LambdaQueryWrapper<ProductionOrderRouteItemParam>()
|
.eq(ProductionOrderRouteItemParam::getOrderId, orderId)
|
.eq(ProductionOrderRouteItemParam::getRouteItemId, routeItemId)
|
.orderByAsc(ProductionOrderRouteItemParam::getSort));
|
|
return list.stream().map(item -> {
|
ProductionOrderRouteItemParamDto dto = new ProductionOrderRouteItemParamDto();
|
BeanUtils.copyProperties(item, dto);
|
return dto;
|
}).collect(Collectors.toList());
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void addRouteItemParam(ProductionOrderRouteItemParamDto dto) {
|
if (dto == null) {
|
throw new ServiceException("新增数据不能为空");
|
}
|
if (dto.getOrderId() == null) {
|
throw new ServiceException("生产订单ID不能为空");
|
}
|
if (dto.getRouteItemId() == null) {
|
throw new ServiceException("工艺路线明细ID不能为空");
|
}
|
Long tenantId = SecurityUtils.getLoginUser().getTenantId();
|
|
BaseParam baseParam = baseParamService.getById(dto.getParamId());
|
if (baseParam == null) {
|
throw new ServiceException("新增参数不存在");
|
}
|
|
ProductionOrderRouteItemParam entity = new ProductionOrderRouteItemParam();
|
BeanUtils.copyProperties(dto, entity);
|
entity.setId(null);
|
entity.setOrderId(dto.getOrderId());
|
entity.setRouteItemId(dto.getRouteItemId());
|
entity.setIsRequired(dto.getIsRequired());
|
// 取当前订单+路线明细下最大 sort + 1
|
ProductionOrderRouteItemParam maxSortItem = getOne(new LambdaQueryWrapper<ProductionOrderRouteItemParam>()
|
.select(ProductionOrderRouteItemParam::getSort)
|
.eq(ProductionOrderRouteItemParam::getOrderId, dto.getOrderId())
|
.eq(ProductionOrderRouteItemParam::getRouteItemId, dto.getRouteItemId())
|
.orderByDesc(ProductionOrderRouteItemParam::getSort)
|
.last("limit 1"));
|
entity.setSort(maxSortItem != null && maxSortItem.getSort() != null ? maxSortItem.getSort() + 1 : 1);
|
entity.setParamKey(baseParam.getParamKey());
|
entity.setParamName(baseParam.getParamName());
|
entity.setParamFormat(baseParam.getParamFormat());
|
entity.setParamType(baseParam.getParamType());
|
entity.setValueMode(baseParam.getValueMode());
|
entity.setUnit(baseParam.getUnit());
|
entity.setRemark(baseParam.getRemark());
|
entity.setTenantId(tenantId);
|
entity.setCreateTime(LocalDateTime.now());
|
save(entity);
|
}
|
|
@Override
|
public void updateRouteItemParam(ProductionOrderRouteItemParamDto dto) {
|
if (dto == null || dto.getId() == null) {
|
throw new ServiceException("更新数据或ID不能为空");
|
}
|
if (getById(dto.getId()) == null) {
|
throw new ServiceException("数据不存在");
|
}
|
ProductionOrderRouteItemParam entity = new ProductionOrderRouteItemParam();
|
BeanUtils.copyProperties(dto, entity);
|
entity.setUpdateTime(LocalDateTime.now());
|
updateById(entity);
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void deleteRouteItemParam(Long id) {
|
if (id == null) {
|
throw new ServiceException("ID不能为空");
|
}
|
if (getById(id) == null) {
|
throw new ServiceException("数据不存在");
|
}
|
removeById(id);
|
}
|
}
|
