websocket代码整理

yangys

2024-05-18 c9b04383c77f91ac309e37e70783edcf8a9298b5

 smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/service/impl/MaterialServiceImpl.java

@@ -56,7 +56,6 @@
import org.springframework.web.multipart.MultipartFile;

@Service
/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/cps/service/impl/MaterialServiceImpl.class */
public class MaterialServiceImpl extends BaseServiceImpl<MaterialMapper, Material> implements IMaterialService {
    private static final Logger log = LoggerFactory.getLogger(MaterialServiceImpl.class);
    private final IMaterialTypeService materialTypeService;
@@ -70,7 +69,7 @@
        this.codeGeneratorService = codeGeneratorService;
    }

    @Override // org.springblade.modules.cps.service.IMaterialService
    
    public List<MaterialVO> listByProperty(Integer property) {
        List<MaterialType> materialTypeList = this.materialTypeService.list();
        Map<Long, MaterialType> typeIdToValue = materialTypeList.stream().collect(Collectors.toMap((v0) -> {
@@ -98,7 +97,7 @@
        return materialVoList;
    }

    @Override // org.springblade.modules.cps.service.IMaterialService
    
    public IPage<MaterialVO> getPageMaterial(MaterialQueryVO vo, Query query) {
        Integer status = Func.isNull(vo.getStatus()) ? CommonConstant.ENABLE : vo.getStatus();
        
@@ -116,7 +115,7 @@
        return this.baseMapper.getPageMaterial(Condition.getPage(query), Func.isNotBlank(wrapper.getSqlSegment()) ? wrapper : null);
    }

    @Override // org.springblade.modules.cps.service.IMaterialService
    
    public boolean checkMaterialIsExist(List<Long> idList) {
       List<Material> materialList = list(Wrappers.<Material>query().lambda()
               .eq(Func.isNotEmpty(AuthUtil.getTenantId()), Material::getTenantId, AuthUtil.getTenantId())
@@ -133,7 +132,7 @@
        return Func.isNotEmpty(materialList);
    }

    @Override // org.springblade.modules.cps.service.IMaterialService
    
    public MaterialVO createMaterial(MaterialAddVO materialAddVO) {
        MaterialType materialType = (MaterialType) this.materialTypeService.getById(materialAddVO.getTypeId());
        if (Func.isEmpty(materialType)) {
@@ -177,7 +176,7 @@
        }
    }

    @Override // org.springblade.modules.cps.service.IMaterialService
    
    public MaterialVO updateMaterial(MaterialUpdateVO materialUpdateVO) {
        MaterialType materialType = (MaterialType) this.materialTypeService.getById(materialUpdateVO.getTypeId());
        if (Func.isEmpty(materialType)) {
@@ -189,7 +188,7 @@
        return MaterialConvert.INSTANCE.convert(material);
    }

    @Override // org.springblade.modules.cps.service.IMaterialService
    
    @Transactional(rollbackFor = {Exception.class})
    public boolean deleteMaterial(List<String> ids, Integer type) {
        List<Long> idList = ids.stream().map(Long::valueOf).collect(Collectors.toList());
@@ -199,7 +198,7 @@
        return changeStatus(idList, CommonConstant.DEACTIVATE);
    }

    @Override // org.springblade.modules.cps.service.IMaterialService
    
    public BladeFile importMaterial(List<MaterialImport> data) {
        if (Func.isEmpty(data)) {
            throw new ServiceException(MessageUtils.message("excel.import.data.can.not.be.null", new Object[0]));
@@ -244,7 +243,7 @@
        return null;
    }

    @Override // org.springblade.modules.cps.service.IMaterialService
    
    public BladeFile exportMaterial(MaterialQueryVO materialQueryVO, HttpServletResponse response) {
        Integer status = materialQueryVO.getStatus();
        if (Func.isNull(status)) {
@@ -261,7 +260,7 @@
        return this.ossBuilder.tempTemplate().putFile(multipartFile.getOriginalFilename(), multipartFile);
    }

    @Override // org.springblade.modules.cps.service.IMaterialService
    
    public List<MaterialVO> getMaterialListByIds(MaterialIdListVO materialIdListVO) {
        List<Material> materialList = listByIds(materialIdListVO.getIds());
        List<Long> typeIdList = materialList.stream().map((v0) -> {
@@ -283,7 +282,7 @@
        return result;
    }

    @Override // org.springblade.modules.cps.service.IMaterialService
    
    @Transactional(rollbackFor = {Exception.class})
    public Boolean synchronizedMaterial(SynchronizedProductMaterialVO synchronizedProductMaterialVO) {
        List<String> nameList = synchronizedProductMaterialVO.getProductList().stream().map(i -> {