package com.qianwen.smartman.modules.cps.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.Wrapper;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import java.lang.invoke.SerializedLambda;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.stream.Collectors;
|
import com.qianwen.smartman.common.utils.MessageUtils;
|
import com.qianwen.core.log.exception.ServiceException;
|
import com.qianwen.core.tool.utils.Func;
|
import com.qianwen.smartman.modules.cps.convert.ProcessAssociationConvert;
|
import com.qianwen.smartman.modules.cps.entity.ProcessAssociation;
|
import com.qianwen.smartman.modules.cps.entity.Supplier;
|
import com.qianwen.smartman.modules.cps.entity.WarehouseArea;
|
import com.qianwen.smartman.modules.cps.entity.Workstation;
|
import com.qianwen.smartman.modules.cps.mapper.ProcessAssociationMapper;
|
import com.qianwen.smartman.modules.cps.service.IProcessAssociationService;
|
import com.qianwen.smartman.modules.cps.service.ISupplierService;
|
import com.qianwen.smartman.modules.cps.service.IWarehouseAreaService;
|
import com.qianwen.smartman.modules.cps.service.IWorkstationService;
|
import com.qianwen.smartman.modules.cps.vo.ProcessAssociationDetailVO;
|
import com.qianwen.smartman.modules.cps.vo.ProcessAssociationSaveVO;
|
import com.qianwen.smartman.modules.cps.vo.ProcessAssociationVO;
|
import com.qianwen.smartman.modules.cps.vo.ProcessSupplierTypeVO;
|
import com.qianwen.smartman.modules.cps.vo.ProcessWarehouseAreaTypeVO;
|
import com.qianwen.smartman.modules.cps.vo.ProcessWorkstationTypeVO;
|
import org.springframework.stereotype.Service;
|
|
@Service
|
/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/cps/service/impl/ProcessAssociationServiceImpl.class */
|
public class ProcessAssociationServiceImpl extends ServiceImpl<ProcessAssociationMapper, ProcessAssociation> implements IProcessAssociationService {
|
private final IWorkstationService workstationService;
|
private final ISupplierService supplierService;
|
private final IWarehouseAreaService warehouseAreaService;
|
|
private static /* synthetic */ Object $deserializeLambda$(SerializedLambda lambda) {
|
String implMethodName = lambda.getImplMethodName();
|
boolean z = true;
|
switch (implMethodName.hashCode()) {
|
case -1104365260:
|
if (implMethodName.equals("getProcessId")) {
|
z = false;
|
break;
|
}
|
break;
|
case 98245393:
|
if (implMethodName.equals("getId")) {
|
z = true;
|
break;
|
}
|
break;
|
case 1949578200:
|
if (implMethodName.equals("getBizId")) {
|
z = true;
|
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/ProcessAssociation") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
|
return (v0) -> {
|
return v0.getProcessId();
|
};
|
}
|
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/ProcessAssociation") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
|
return (v0) -> {
|
return v0.getProcessId();
|
};
|
}
|
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/ProcessAssociation") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
|
return (v0) -> {
|
return v0.getProcessId();
|
};
|
}
|
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();
|
};
|
}
|
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/ProcessAssociation") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
|
return (v0) -> {
|
return v0.getBizId();
|
};
|
}
|
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/ProcessAssociation") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
|
return (v0) -> {
|
return v0.getBizId();
|
};
|
}
|
break;
|
}
|
throw new IllegalArgumentException("Invalid lambda deserialization");
|
}
|
|
public ProcessAssociationServiceImpl(final IWorkstationService workstationService, final ISupplierService supplierService, final IWarehouseAreaService warehouseAreaService) {
|
this.workstationService = workstationService;
|
this.supplierService = supplierService;
|
this.warehouseAreaService = warehouseAreaService;
|
}
|
|
@Override // org.springblade.modules.cps.service.IProcessAssociationService
|
public ProcessAssociationVO listAssociation(Long processId) {
|
ProcessAssociationVO processAssociationVO = new ProcessAssociationVO();
|
List<ProcessAssociation> processAssociationList = list((Wrapper) Wrappers.query().lambda().eq((v0) -> {
|
return v0.getProcessId();
|
}, processId));
|
if (Func.isNotEmpty(processAssociationList)) {
|
Map<Integer, List<ProcessAssociation>> map = (Map) processAssociationList.stream().filter(type -> {
|
return type.getType() != null;
|
}).collect(Collectors.groupingBy((v0) -> {
|
return v0.getType();
|
}));
|
map.forEach(type2, value -> {
|
switch (type2.intValue()) {
|
case 1:
|
List<Long> list = (List) value.stream().map((v0) -> {
|
return v0.getBizId();
|
}).collect(Collectors.toList());
|
List<Workstation> workstationList = this.workstationService.list((Wrapper) Wrappers.query().lambda().in((v0) -> {
|
return v0.getId();
|
}, list));
|
List<ProcessWorkstationTypeVO> processWorkstationTypeVOList = new ArrayList<>();
|
workstationList.forEach(record -> {
|
ProcessWorkstationTypeVO processWorkstationTypeVO = ProcessWorkstationTypeVO.builder().id(record.getId()).workstationCode(record.getCode()).workstationName(record.getName()).build();
|
processWorkstationTypeVOList.add(processWorkstationTypeVO);
|
});
|
processAssociationVO.setWorkstationList(processWorkstationTypeVOList);
|
return;
|
case 2:
|
List<Long> list2 = (List) value.stream().map((v0) -> {
|
return v0.getBizId();
|
}).collect(Collectors.toList());
|
List<WarehouseArea> warehouseAreaList = this.warehouseAreaService.list((Wrapper) Wrappers.query().lambda().in((v0) -> {
|
return v0.getId();
|
}, list2));
|
List<ProcessWarehouseAreaTypeVO> areaTypeVOList = new ArrayList<>();
|
warehouseAreaList.forEach(record2 -> {
|
ProcessWarehouseAreaTypeVO processWarehouseAreaTypeVO = ProcessWarehouseAreaTypeVO.builder().id(record2.getId()).warehouseAreaCode(record2.getCode()).warehouseAreaName(record2.getName()).build();
|
areaTypeVOList.add(processWarehouseAreaTypeVO);
|
});
|
processAssociationVO.setWarehouseAreaList(areaTypeVOList);
|
return;
|
case 3:
|
List<Long> list3 = (List) value.stream().map((v0) -> {
|
return v0.getBizId();
|
}).collect(Collectors.toList());
|
List<Supplier> supplierList = this.supplierService.list((Wrapper) Wrappers.query().lambda().in((v0) -> {
|
return v0.getId();
|
}, list3));
|
List<ProcessSupplierTypeVO> processSupplierTypeVOList = new ArrayList<>();
|
supplierList.forEach(record3 -> {
|
ProcessSupplierTypeVO processSupplierTypeVO = ProcessSupplierTypeVO.builder().id(record3.getId()).supplierCode(record3.getCode()).supplierName(record3.getName()).build();
|
processSupplierTypeVOList.add(processSupplierTypeVO);
|
});
|
processAssociationVO.setSupplierList(processSupplierTypeVOList);
|
return;
|
default:
|
return;
|
}
|
});
|
}
|
return processAssociationVO;
|
}
|
|
@Override // org.springblade.modules.cps.service.IProcessAssociationService
|
public ProcessAssociationDetailVO insert(ProcessAssociationSaveVO processAssociationSaveVO) {
|
checkProcessAssociation(processAssociationSaveVO);
|
ProcessAssociation processAssociation = ProcessAssociationConvert.INSTANCE.convert(processAssociationSaveVO);
|
save(processAssociation);
|
return ProcessAssociationConvert.INSTANCE.convert(processAssociation);
|
}
|
|
@Override // org.springblade.modules.cps.service.IProcessAssociationService
|
public Boolean delete(Long bizId, Long processId) {
|
return Boolean.valueOf(remove(Wrappers.query().lambda().eq(Func.isNotEmpty(bizId), (v0) -> {
|
return v0.getBizId();
|
}, bizId).eq(Func.isNotEmpty(processId), (v0) -> {
|
return v0.getProcessId();
|
}, processId)));
|
}
|
|
private void checkProcessAssociation(ProcessAssociationSaveVO processAssociationSaveVO) {
|
Long count = Long.valueOf(count(Wrappers.query().lambda().eq(Func.isNotEmpty(processAssociationSaveVO.getProcessId()), (v0) -> {
|
return v0.getProcessId();
|
}, processAssociationSaveVO.getProcessId()).eq(Func.isNotEmpty(processAssociationSaveVO.getBizId()), (v0) -> {
|
return v0.getBizId();
|
}, processAssociationSaveVO.getBizId())));
|
if (count.longValue() > 0) {
|
throw new ServiceException(MessageUtils.message("cps.process.association.type.already.exists", new Object[0]));
|
}
|
}
|
}
|
