package com.qianwen.smartman.modules.cps.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.Wrapper;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.core.toolkit.support.SFunction;
|
import com.google.common.collect.Lists;
|
import java.lang.invoke.SerializedLambda;
|
import java.math.BigDecimal;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.stream.Collectors;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import com.qianwen.smartman.common.cache.RegionCache;
|
import com.qianwen.smartman.common.constant.CraftConstant;
|
import com.qianwen.smartman.common.utils.MessageUtils;
|
import com.qianwen.core.mp.service.impl.BladeServiceImpl;
|
import com.qianwen.core.tool.support.Kv;
|
import com.qianwen.core.tool.utils.Func;
|
import com.qianwen.core.tool.utils.RandomType;
|
import com.qianwen.core.tool.utils.StringUtil;
|
import com.qianwen.smartman.modules.cps.convert.CraftRoutingConvert;
|
import com.qianwen.smartman.modules.cps.convert.ProductConvert;
|
import com.qianwen.smartman.modules.cps.convert.ProductionCraftProcessConvert;
|
import com.qianwen.smartman.modules.cps.dto.CraftVersionDTO;
|
import com.qianwen.smartman.modules.cps.entity.CraftRouting;
|
import com.qianwen.smartman.modules.cps.entity.CraftVersionLine;
|
import com.qianwen.smartman.modules.cps.entity.Product;
|
import com.qianwen.smartman.modules.cps.entity.ProductionCraftProcess;
|
import com.qianwen.smartman.modules.cps.entity.ProductionCraftProcessFile;
|
import com.qianwen.smartman.modules.cps.entity.ProductionCraftProcessRelatedFixture;
|
import com.qianwen.smartman.modules.cps.entity.ProductionCraftProcessRelatedTool;
|
import com.qianwen.smartman.modules.cps.entity.ProductionCraftVersion;
|
import com.qianwen.smartman.modules.cps.mapper.CraftRoutingMapper;
|
import com.qianwen.smartman.modules.cps.service.ICraftRoutingService;
|
import com.qianwen.smartman.modules.cps.service.ICraftVersionLineService;
|
import com.qianwen.smartman.modules.cps.service.IProductService;
|
import com.qianwen.smartman.modules.cps.service.IProductionCraftProcessFileService;
|
import com.qianwen.smartman.modules.cps.service.IProductionCraftProcessRelatedFixtureService;
|
import com.qianwen.smartman.modules.cps.service.IProductionCraftProcessRelatedToolService;
|
import com.qianwen.smartman.modules.cps.service.IProductionCraftProcessService;
|
import com.qianwen.smartman.modules.cps.service.IProductionCraftVersionService;
|
import com.qianwen.smartman.modules.cps.utils.ThrowFun;
|
import com.qianwen.smartman.modules.cps.vo.CraftRoutingAddVO;
|
import com.qianwen.smartman.modules.cps.vo.CraftRoutingDetailVO;
|
import com.qianwen.smartman.modules.cps.vo.CraftRoutingUpdateVO;
|
import com.qianwen.smartman.modules.cps.vo.CraftRoutingVO;
|
import com.qianwen.smartman.modules.cps.vo.CraftVersionAddVO;
|
import com.qianwen.smartman.modules.cps.vo.ParallelProVO;
|
import com.qianwen.smartman.modules.cps.vo.ProcessParallelSaveVO;
|
import com.qianwen.smartman.modules.cps.vo.ProductVO;
|
import com.qianwen.smartman.modules.cps.vo.ProductionCraftProcessFileVO;
|
import com.qianwen.smartman.modules.cps.vo.ProductionCraftProcessRelatedFixtureVO;
|
import com.qianwen.smartman.modules.cps.vo.ProductionCraftProcessRelatedToolVO;
|
import com.qianwen.smartman.modules.cps.vo.ProductionCraftProcessVO;
|
import com.qianwen.smartman.modules.cps.vo.ProductionCraftVersionCopyVO;
|
import com.qianwen.smartman.modules.cps.vo.ProductionCraftVersionVO;
|
import com.qianwen.smartman.modules.cps.vo.SearchVO;
|
import com.qianwen.smartman.modules.cps.vo.VersionProcessAddVO;
|
import com.qianwen.smartman.modules.system.service.IBasCoderuleService;
|
import com.qianwen.smartman.modules.tpm.enums.MetaTypeEnum;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
@Service
|
/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/cps/service/impl/CraftRoutingServiceImpl.class */
|
public class CraftRoutingServiceImpl extends BladeServiceImpl<CraftRoutingMapper, CraftRouting> implements ICraftRoutingService {
|
private static final Logger log = LoggerFactory.getLogger(CraftRoutingServiceImpl.class);
|
private final IProductionCraftVersionService craftVersionService;
|
private final ICraftVersionLineService versionLineService;
|
private final IProductService productService;
|
private final IProductionCraftProcessService craftProcessService;
|
private final IProductionCraftProcessRelatedFixtureService relatedFixtureService;
|
private final IProductionCraftProcessRelatedToolService relatedToolService;
|
private final IProductionCraftProcessFileService processFileService;
|
private final IBasCoderuleService basCodeRuleService;
|
|
private static /* synthetic */ Object $deserializeLambda$(SerializedLambda lambda) {
|
String implMethodName = lambda.getImplMethodName();
|
boolean z = true;
|
switch (implMethodName.hashCode()) {
|
case -1416707747:
|
if (implMethodName.equals("getVersionId")) {
|
z = true;
|
break;
|
}
|
break;
|
case -1291082392:
|
if (implMethodName.equals("getVersionProcessId")) {
|
z = true;
|
break;
|
}
|
break;
|
case -1061435468:
|
if (implMethodName.equals("getProductId")) {
|
z = true;
|
break;
|
}
|
break;
|
case -75308287:
|
if (implMethodName.equals("getName")) {
|
z = true;
|
break;
|
}
|
break;
|
case 98245393:
|
if (implMethodName.equals("getId")) {
|
z = true;
|
break;
|
}
|
break;
|
case 1330288580:
|
if (implMethodName.equals("getGroupId")) {
|
z = true;
|
break;
|
}
|
break;
|
case 2061868837:
|
if (implMethodName.equals("getCraftId")) {
|
z = false;
|
break;
|
}
|
break;
|
}
|
switch (z) {
|
case false:
|
if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/cps/entity/ProductionCraftVersion") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
|
return (v0) -> {
|
return v0.getCraftId();
|
};
|
}
|
if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/cps/entity/CraftVersionLine") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
|
return (v0) -> {
|
return v0.getCraftId();
|
};
|
}
|
break;
|
case true:
|
if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/cps/entity/ProductionCraftProcess") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
|
return (v0) -> {
|
return v0.getVersionId();
|
};
|
}
|
if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/cps/entity/ProductionCraftProcess") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
|
return (v0) -> {
|
return v0.getVersionId();
|
};
|
}
|
if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/cps/entity/CraftVersionLine") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
|
return (v0) -> {
|
return v0.getVersionId();
|
};
|
}
|
break;
|
case true:
|
if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/cps/entity/ProductionCraftProcessRelatedFixture") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
|
return (v0) -> {
|
return v0.getVersionProcessId();
|
};
|
}
|
if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/cps/entity/ProductionCraftProcessRelatedTool") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
|
return (v0) -> {
|
return v0.getVersionProcessId();
|
};
|
}
|
if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/cps/entity/ProductionCraftProcessFile") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
|
return (v0) -> {
|
return v0.getVersionProcessId();
|
};
|
}
|
break;
|
case true:
|
if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/cps/entity/CraftRouting") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) {
|
return (v0) -> {
|
return v0.getName();
|
};
|
}
|
break;
|
case true:
|
if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/core/mp/base/BaseEntity") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
|
return (v0) -> {
|
return v0.getId();
|
};
|
}
|
if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/core/mp/base/BaseEntity") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
|
return (v0) -> {
|
return v0.getId();
|
};
|
}
|
if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/core/mp/base/BaseEntity") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
|
return (v0) -> {
|
return v0.getId();
|
};
|
}
|
if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/core/mp/base/BaseEntity") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
|
return (v0) -> {
|
return v0.getId();
|
};
|
}
|
break;
|
case RegionCache.VILLAGE_LEVEL /* 5 */:
|
if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/cps/entity/CraftVersionLine") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
|
return (v0) -> {
|
return v0.getGroupId();
|
};
|
}
|
break;
|
case true:
|
if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/cps/entity/CraftRouting") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
|
return (v0) -> {
|
return v0.getProductId();
|
};
|
}
|
if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/cps/entity/CraftRouting") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
|
return (v0) -> {
|
return v0.getProductId();
|
};
|
}
|
if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/cps/entity/CraftRouting") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
|
return (v0) -> {
|
return v0.getProductId();
|
};
|
}
|
if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/cps/entity/CraftRouting") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
|
return (v0) -> {
|
return v0.getProductId();
|
};
|
}
|
if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/cps/entity/CraftRouting") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
|
return (v0) -> {
|
return v0.getProductId();
|
};
|
}
|
if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/cps/entity/CraftRouting") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
|
return (v0) -> {
|
return v0.getProductId();
|
};
|
}
|
break;
|
}
|
throw new IllegalArgumentException("Invalid lambda deserialization");
|
}
|
|
public CraftRoutingServiceImpl(final IProductionCraftVersionService craftVersionService, final ICraftVersionLineService versionLineService, final IProductService productService, final IProductionCraftProcessService craftProcessService, final IProductionCraftProcessRelatedFixtureService relatedFixtureService, final IProductionCraftProcessRelatedToolService relatedToolService, final IProductionCraftProcessFileService processFileService, final IBasCoderuleService basCodeRuleService) {
|
this.craftVersionService = craftVersionService;
|
this.versionLineService = versionLineService;
|
this.productService = productService;
|
this.craftProcessService = craftProcessService;
|
this.relatedFixtureService = relatedFixtureService;
|
this.relatedToolService = relatedToolService;
|
this.processFileService = processFileService;
|
this.basCodeRuleService = basCodeRuleService;
|
}
|
|
@Override // org.springblade.modules.cps.service.ICraftRoutingService
|
public CraftRoutingVO saveRouting(CraftRoutingAddVO vo) {
|
CraftRouting craftRouting = saveCraftRouting(vo);
|
return CraftRoutingConvert.INSTANCE.convert(craftRouting);
|
}
|
|
@Override // org.springblade.modules.cps.service.ICraftRoutingService
|
public List<CraftRoutingVO> listCraftRouting(SearchVO vo) {
|
Wrapper<CraftRouting> wrapper = getWrapper(vo);
|
return this.baseMapper.listCraftRouting(Func.isBlank(wrapper.getSqlSegment()) ? null : wrapper);
|
}
|
|
@Override // org.springblade.modules.cps.service.ICraftRoutingService
|
public CraftRoutingDetailVO detailCraft(Long id) {
|
CraftRoutingDetailVO vo = new CraftRoutingDetailVO();
|
setProduce(vo, id);
|
setCraftVersion(vo, id);
|
return vo;
|
}
|
|
@Override // org.springblade.modules.cps.service.ICraftRoutingService
|
@Transactional(rollbackFor = {Exception.class})
|
public Boolean deleteCraft(Long id) {
|
boolean flag = removeById(id);
|
List<Long> versionIds = this.craftVersionService.listObjs((Wrapper) Wrappers.lambdaQuery(ProductionCraftVersion.class).select(new SFunction[]{(v0) -> {
|
return v0.getId();
|
}}).eq((v0) -> {
|
return v0.getCraftId();
|
}, id), c -> {
|
return Long.valueOf(c instanceof BigDecimal ? ((BigDecimal) c).longValue() : ((Long) c).longValue());
|
});
|
if (Func.isNotEmpty(versionIds)) {
|
flag = flag && this.craftVersionService.removeVersion(versionIds).booleanValue();
|
}
|
return Boolean.valueOf(flag && this.versionLineService.remove((Wrapper) Wrappers.lambdaQuery().eq((v0) -> {
|
return v0.getCraftId();
|
}, id)));
|
}
|
|
@Override // org.springblade.modules.cps.service.ICraftRoutingService
|
public Boolean updateCraft(CraftRoutingUpdateVO vo) {
|
validNameExist(vo.getId(), vo.getName());
|
CraftRouting routing = CraftRoutingConvert.INSTANCE.convert(vo);
|
return Boolean.valueOf(updateById(routing));
|
}
|
|
@Override // org.springblade.modules.cps.service.ICraftRoutingService
|
@Transactional(rollbackFor = {Exception.class})
|
public Boolean copyCraftVersion(ProductionCraftVersionCopyVO vo) {
|
Integer type = vo.getType();
|
if (CraftConstant.COPY_TYPE_PRODUCT.equals(type)) {
|
CraftRouting routing = (CraftRouting) getOne((Wrapper) Wrappers.lambdaQuery(CraftRouting.class).eq((v0) -> {
|
return v0.getProductId();
|
}, vo.getProductId()));
|
if (Func.isNull(routing)) {
|
return Boolean.valueOf(copyProductNewCraft(vo));
|
}
|
return Boolean.valueOf(copyCraftNewVersion(vo, routing.getId()));
|
}
|
return Boolean.valueOf(copyCraftNewVersion(vo, vo.getCraftId()));
|
}
|
|
@Override // org.springblade.modules.cps.service.ICraftRoutingService
|
public List<ProductionCraftVersionVO> listFixedVersionByProduction(Long productionId) {
|
CraftRouting craft = (CraftRouting) getOne((Wrapper) Wrappers.lambdaQuery(CraftRouting.class).eq((v0) -> {
|
return v0.getProductId();
|
}, productionId));
|
if (Func.isNull(craft)) {
|
return Lists.newArrayList();
|
}
|
return this.craftVersionService.listFixed(craft.getId());
|
}
|
|
@Override // org.springblade.modules.cps.service.ICraftRoutingService
|
public CraftRoutingDetailVO getCraftByProduction(Long production) {
|
CraftRouting craft = (CraftRouting) getOne((Wrapper) Wrappers.lambdaQuery(CraftRouting.class).eq((v0) -> {
|
return v0.getProductId();
|
}, production));
|
if (Func.isNull(craft)) {
|
return null;
|
}
|
return detailCraft(craft.getId());
|
}
|
|
@Override // org.springblade.modules.cps.service.ICraftRoutingService
|
public List<CraftRoutingVO> listNotBandCraft() {
|
return CraftRoutingConvert.INSTANCE.convert(list((Wrapper) Wrappers.lambdaQuery(CraftRouting.class).isNull((v0) -> {
|
return v0.getProductId();
|
})));
|
}
|
|
@Override // org.springblade.modules.cps.service.ICraftRoutingService
|
public Boolean craftBindProduction(Long productionId, Long craftId) {
|
return Boolean.valueOf(update((Wrapper) ((LambdaUpdateWrapper) Wrappers.lambdaUpdate(CraftRouting.class).set((v0) -> {
|
return v0.getProductId();
|
}, productionId)).eq((v0) -> {
|
return v0.getId();
|
}, craftId)));
|
}
|
|
@Override // org.springblade.modules.cps.service.ICraftRoutingService
|
public Boolean craftUnbindProduction(Long craftId) {
|
return Boolean.valueOf(update((Wrapper) ((LambdaUpdateWrapper) Wrappers.lambdaUpdate(CraftRouting.class).set((v0) -> {
|
return v0.getProductId();
|
}, (Object) null)).eq((v0) -> {
|
return v0.getId();
|
}, craftId)));
|
}
|
|
@Override // org.springblade.modules.cps.service.ICraftRoutingService
|
public List<ProductVO> notBandProduct(Long craftId) {
|
List<Product> products = this.productService.notBandProduct(craftId);
|
return ProductConvert.INSTANCE.convert(products);
|
}
|
|
private boolean copyCraftNewVersion(ProductionCraftVersionCopyVO vo, Long craftId) {
|
Long versionId = vo.getVersionId();
|
ProductionCraftVersion version = (ProductionCraftVersion) this.craftVersionService.getById(versionId);
|
CraftVersionAddVO newVersion = new CraftVersionAddVO();
|
boolean existCodeRule = this.basCodeRuleService.isExistCodeRule(MetaTypeEnum.PRODUCTION_CRAFT_VERSION.getCode());
|
if (!existCodeRule) {
|
newVersion.setName(version.getName() + Func.random(4, RandomType.STRING));
|
}
|
newVersion.setDescription(version.getDescription());
|
newVersion.setGroupIds(getGroupIds(versionId));
|
ProductionCraftVersionVO craftVersion = this.craftVersionService.saveCraftVersion(craftId, newVersion);
|
List<ProductionCraftProcess> processList = this.craftProcessService.list((Wrapper) Wrappers.lambdaQuery(ProductionCraftProcess.class).eq((v0) -> {
|
return v0.getVersionId();
|
}, version.getId()));
|
ProcessParallelSaveVO saveVO = copyProductNewCraftProcess(craftVersion.getId(), processList);
|
List<ProductionCraftProcessVO> vos = this.craftProcessService.parallelSave(saveVO);
|
return Func.isNotEmpty(vos);
|
}
|
|
private boolean copyProductNewCraft(ProductionCraftVersionCopyVO vo) {
|
CraftRoutingAddVO newCraft = new CraftRoutingAddVO();
|
String newCraftName = vo.getCraftName() + Func.random(4, RandomType.STRING);
|
newCraft.setName(newCraftName);
|
newCraft.setProductId(vo.getProductId());
|
CraftRouting craftRouting = saveCraftRouting(newCraft);
|
Long versionId = vo.getVersionId();
|
ProductionCraftVersion version = (ProductionCraftVersion) this.craftVersionService.getById(versionId);
|
CraftVersionAddVO newVersion = new CraftVersionAddVO();
|
newVersion.setName(version.getName());
|
newVersion.setDescription(version.getDescription());
|
newVersion.setGroupIds(getGroupIds(versionId));
|
ProductionCraftVersionVO craftVersion = this.craftVersionService.saveCraftVersion(craftRouting.getId(), newVersion);
|
List<ProductionCraftProcess> processList = this.craftProcessService.list((Wrapper) Wrappers.lambdaQuery(ProductionCraftProcess.class).eq((v0) -> {
|
return v0.getVersionId();
|
}, version.getId()));
|
ProcessParallelSaveVO saveVO = copyProductNewCraftProcess(craftVersion.getId(), processList);
|
List<ProductionCraftProcessVO> vos = this.craftProcessService.parallelSave(saveVO);
|
return Func.isNotEmpty(vos);
|
}
|
|
private ProcessParallelSaveVO copyProductNewCraftProcess(Long versionId, List<ProductionCraftProcess> processList) {
|
ProcessParallelSaveVO vo = new ProcessParallelSaveVO();
|
if (Func.isNotEmpty(processList)) {
|
List<Long> processIds = (List) processList.stream().map((v0) -> {
|
return v0.getId();
|
}).collect(Collectors.toList());
|
Map<Long, List<ProductionCraftProcessRelatedFixture>> processFixtureMap = (Map) this.relatedFixtureService.list((Wrapper) Wrappers.lambdaQuery(ProductionCraftProcessRelatedFixture.class).in((v0) -> {
|
return v0.getVersionProcessId();
|
}, processIds)).stream().collect(Collectors.groupingBy((v0) -> {
|
return v0.getVersionProcessId();
|
}));
|
Map<Long, List<ProductionCraftProcessRelatedTool>> processToolMap = (Map) this.relatedToolService.list((Wrapper) Wrappers.lambdaQuery(ProductionCraftProcessRelatedTool.class).in((v0) -> {
|
return v0.getVersionProcessId();
|
}, processIds)).stream().collect(Collectors.groupingBy((v0) -> {
|
return v0.getVersionProcessId();
|
}));
|
Map<Long, List<ProductionCraftProcessFile>> processFileMap = (Map) this.processFileService.list((Wrapper) Wrappers.lambdaQuery(ProductionCraftProcessFile.class).in((v0) -> {
|
return v0.getVersionProcessId();
|
}, processIds)).stream().collect(Collectors.groupingBy((v0) -> {
|
return v0.getVersionProcessId();
|
}));
|
List<VersionProcessAddVO> collect = (List) processList.stream().filter(c -> {
|
return Func.isNull(c.getMainSequenceId()) && Func.notNull(c.getProcessId());
|
}).map(process -> {
|
return getVersionProcessAddVO(processFixtureMap, processToolMap, processFileMap, process);
|
}).collect(Collectors.toList());
|
List<ProductionCraftProcess> list = (List) processList.stream().filter(c2 -> {
|
return Func.notNull(c2.getMainSequenceId()) || Func.isNull(c2.getProcessId());
|
}).collect(Collectors.toList());
|
List<ParallelProVO> parallelProcessList = Lists.newArrayList();
|
list.stream().filter(l1 -> {
|
return Func.isNull(l1.getProcessId());
|
}).forEach(l12 -> {
|
ParallelProVO proVO = new ParallelProVO();
|
proVO.setProcessCode(l12.getProcessCode());
|
proVO.setProcessName(l12.getProcessName());
|
proVO.setSort(l12.getSort());
|
proVO.setSourceId(l12.getSourceId());
|
proVO.setTargetId(l12.getTargetId());
|
proVO.setXCoordinate(l12.getXCoordinate());
|
proVO.setYCoordinate(l12.getYCoordinate());
|
proVO.setHeight(l12.getHeight());
|
List<VersionProcessAddVO> vos = (List) list.stream().filter(l2 -> {
|
return l12.getId().equals(l2.getMainSequenceId());
|
}).map(process2 -> {
|
return getVersionProcessAddVO(processFixtureMap, processToolMap, processFileMap, process2);
|
}).collect(Collectors.toList());
|
proVO.setChildProcessList(vos);
|
parallelProcessList.add(proVO);
|
});
|
vo.setNormalProcessList(collect);
|
vo.setParallelProcessList(parallelProcessList);
|
}
|
vo.setVersionId(versionId);
|
return vo;
|
}
|
|
/* JADX INFO: Access modifiers changed from: private */
|
public static VersionProcessAddVO getVersionProcessAddVO(Map<Long, List<ProductionCraftProcessRelatedFixture>> processFixtureMap, Map<Long, List<ProductionCraftProcessRelatedTool>> processToolMap, Map<Long, List<ProductionCraftProcessFile>> processFileMap, ProductionCraftProcess process) {
|
VersionProcessAddVO processAddVO = ProductionCraftProcessConvert.INSTANCE.convertAdd(process);
|
List<ProductionCraftProcessRelatedFixture> fixtures = processFixtureMap.get(process.getId());
|
if (Func.isNotEmpty(fixtures)) {
|
List<ProductionCraftProcessRelatedFixtureVO> fixtureAddList = (List) fixtures.stream().map(c -> {
|
return new ProductionCraftProcessRelatedFixtureVO().setFixtureId(c.getFixtureId()).setVersionProcessId(c.getVersionProcessId()).setFixtureCode(c.getFixtureCode()).setFixtureName(c.getFixtureName()).setFixtureGroupName(c.getFixtureGroupName());
|
}).collect(Collectors.toList());
|
processAddVO.setFixtures(fixtureAddList);
|
}
|
List<ProductionCraftProcessFile> files = processFileMap.get(process.getId());
|
if (Func.isNotEmpty(files)) {
|
List<ProductionCraftProcessFileVO> fileAddList = (List) files.stream().map(c2 -> {
|
return new ProductionCraftProcessFileVO().setFileName(c2.getFileName()).setObjectKey(c2.getObjectKey()).setContentType(c2.getContentType()).setLink(c2.getLink()).setFileSize(c2.getFileSize()).setUploadTime(c2.getUploadTime()).setVersionProcessId(c2.getVersionProcessId());
|
}).collect(Collectors.toList());
|
processAddVO.setFiles(fileAddList);
|
}
|
List<ProductionCraftProcessRelatedTool> tools = processToolMap.get(process.getId());
|
if (Func.isNotEmpty(tools)) {
|
List<ProductionCraftProcessRelatedToolVO> toolAddList = (List) tools.stream().map(c3 -> {
|
return new ProductionCraftProcessRelatedToolVO().setToolId(c3.getToolId()).setVersionProcessId(c3.getVersionProcessId()).setToolCode(c3.getToolCode()).setToolCategoryName(c3.getToolCategoryName()).setToolModelName(c3.getToolModelName());
|
}).collect(Collectors.toList());
|
processAddVO.setTools(toolAddList);
|
}
|
return processAddVO;
|
}
|
|
private List<Long> getGroupIds(Long versionId) {
|
return this.versionLineService.listObjs((Wrapper) Wrappers.lambdaQuery(CraftVersionLine.class).select(new SFunction[]{(v0) -> {
|
return v0.getGroupId();
|
}}).eq((v0) -> {
|
return v0.getVersionId();
|
}, versionId), c -> {
|
if (c instanceof BigDecimal) {
|
return Long.valueOf(((BigDecimal) c).longValue());
|
}
|
return (Long) c;
|
});
|
}
|
|
private void setProduce(CraftRoutingDetailVO vo, Long id) {
|
CraftRouting craft = (CraftRouting) getById(id);
|
ThrowFun.isTrue(Func.isNull(craft)).throwMessage(MessageUtils.message("cps.craft.not.exist", new Object[0]));
|
vo.setId(id);
|
vo.setName(craft.getName());
|
vo.setDescription(craft.getDescription());
|
vo.setStatus(craft.getStatus());
|
vo.setProductId(craft.getProductId());
|
Long productId = craft.getProductId();
|
if (!Func.isNull(productId)) {
|
Product product = (Product) this.productService.getById(productId);
|
if (!Func.isNull(product)) {
|
vo.setProductCode(product.getCode());
|
vo.setProductName(product.getName());
|
}
|
}
|
}
|
|
private void setCraftVersion(CraftRoutingDetailVO vo, Long id) {
|
List<CraftVersionDTO> craftVersionList = this.craftVersionService.listVersion(id);
|
vo.setDtos(craftVersionList);
|
}
|
|
private QueryWrapper<CraftRouting> getWrapper(SearchVO vo) {
|
List<SearchVO.KV> param = vo.getParams();
|
Map<String, String> params = (Map) param.stream().collect(Collectors.toMap((v0) -> {
|
return v0.getKey();
|
}, (v0) -> {
|
return v0.getValue();
|
}));
|
Kv exclude = Kv.create().set("Blade-Auth", "Blade-Auth").set("current", "current").set("size", "size").set("ascs", "ascs").set("descs", "descs");
|
exclude.forEach(k, v -> {
|
String str = (String) params.remove(k);
|
});
|
QueryWrapper<CraftRouting> wrapper = new QueryWrapper<>();
|
if (Func.isNotEmpty(params)) {
|
params.forEach(k2, v2 -> {
|
if (k2.endsWith(CraftConstant.LIKE)) {
|
wrapper.likeRight("bcr." + getColumn(k2, CraftConstant.LIKE), v2);
|
} else if (k2.endsWith(CraftConstant.ASC)) {
|
wrapper.orderByAsc("bcr." + getColumn(k2, CraftConstant.ASC));
|
} else if (k2.endsWith(CraftConstant.DESC)) {
|
wrapper.orderByDesc("bcr." + getColumn(k2, CraftConstant.DESC));
|
}
|
});
|
}
|
return wrapper;
|
}
|
|
private String getColumn(String column, String keyword) {
|
return StringUtil.humpToUnderline(StringUtil.removeSuffix(column, keyword));
|
}
|
|
private CraftRouting saveCraftRouting(CraftRoutingAddVO vo) {
|
String name = vo.getName();
|
validNameExist(null, name);
|
CraftRouting craftRouting = new CraftRouting().setName(name).setDescription(vo.getDescription()).setProductId(vo.getProductId());
|
save(craftRouting);
|
return craftRouting;
|
}
|
|
private void validNameExist(Long id, String name) {
|
long count = count((Wrapper) Wrappers.lambdaQuery(CraftRouting.class).ne(Func.isNotEmpty(id), (v0) -> {
|
return v0.getId();
|
}, id).eq((v0) -> {
|
return v0.getName();
|
}, name));
|
ThrowFun.isTrue(count > 0).throwMessage(MessageUtils.message("cps.craft.name.exist", new Object[0]));
|
}
|
}
|
