修改lambda错误

yangys

2024-04-10 95a87c5137cb5c8bde751dadccd8cc57a907cc3f

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

@@ -1,13 +1,6 @@
package com.qianwen.smartman.modules.cps.service.impl;

import cn.hutool.core.lang.Assert;
import cn.hutool.core.util.HexUtil;
import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import java.lang.invoke.SerializedLambda;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
import java.util.HashSet;
import java.util.List;
@@ -17,15 +10,20 @@
import java.util.stream.Collectors;
import java.util.stream.Stream;
import java.util.zip.CRC32;
import com.qianwen.smartman.common.cache.RegionCache;
import com.qianwen.smartman.common.cache.cps.WorkstationCache;
import com.qianwen.smartman.common.enums.WcsDataTypeEnums;
import com.qianwen.smartman.common.utils.ExtraLambdaQueryWrapper;
import com.qianwen.smartman.common.utils.Lambda;
import com.qianwen.smartman.common.utils.MessageUtils;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Lazy;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.qianwen.core.log.exception.ServiceException;
import com.qianwen.core.mp.base.BaseServiceImpl;
import com.qianwen.core.tool.utils.Func;
import com.qianwen.smartman.common.cache.cps.WorkstationCache;
import com.qianwen.smartman.common.enums.WcsDataTypeEnums;
import com.qianwen.smartman.common.utils.Lambda;
import com.qianwen.smartman.common.utils.MessageUtils;
import com.qianwen.smartman.modules.cps.convert.WorkstationWcsConvert;
import com.qianwen.smartman.modules.cps.entity.DmpVariables;
import com.qianwen.smartman.modules.cps.entity.WorkstationOfMachine;
@@ -43,10 +41,9 @@
import com.qianwen.smartman.modules.cps.vo.WorkstationWcsSaveVO;
import com.qianwen.smartman.modules.cps.vo.WorkstationWcsVO;
import com.qianwen.smartman.modules.tdengine.service.IWorkstationDynamicCollectService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Lazy;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import cn.hutool.core.lang.Assert;
import cn.hutool.core.util.HexUtil;

@Service
public class WorkstationWcsServiceImpl extends BaseServiceImpl<WorkstationWcsMapper, WorkstationWcs> implements IWorkstationWcsService {
@@ -126,7 +123,7 @@
        return convert;
    }

    @Override // org.springblade.modules.cps.service.IWorkstationWcsService
    @Override 
    @Transactional(rollbackFor = {Exception.class})
    public List<WorkstationWcsVO> insert(List<WorkstationWcsSaveVO> workstationWcsSaveVOList) {
        Long workstationId = workstationWcsSaveVOList.get(0).getWorkstationId();
@@ -142,14 +139,7 @@
                .notIn(Func.isNotEmpty(saveWorkstationWcsList), WorkstationWcs::getCollectSettingItem, saveWorkstationWcsList
                  .stream().map(WorkstationWcs::getCollectSettingItem)
                  .collect(Collectors.toList()))));
        /*
        this.dynamicCollectService.removeTableDeleteWcs(list(Lambda.eq((v0) -> {
            return v0.getWorkstationId();
        }, workstationId).notIn(Func.isNotEmpty(saveWorkstationWcsList), (v0) -> {
            return v0.getCollectSettingItem();
        }, (Collection) saveWorkstationWcsList.stream().map((v0) -> {
            return v0.getCollectSettingItem();
        }).collect(Collectors.toList()))));*/
        
        deleteByWorkstationIdList(Collections.singletonList(workstationId));
        for (WorkstationWcs workstationWcs : saveWorkstationWcsList) {
            checkWorkstationWcs(workstationWcs);
@@ -218,7 +208,7 @@
        workstationWcs.setDataItemCrc(dataItemCrc);
    }

    @Override // org.springblade.modules.cps.service.IWorkstationWcsService
    @Override 
    public WorkstationWcsVO updateSetting(WorkstationWcsSaveVO workstationWcsSaveVO) {
        WorkstationWcs workstationWcs = WorkstationWcsConvert.INSTANCE.convert(workstationWcsSaveVO);
        checkSetting(workstationWcs);
@@ -228,7 +218,7 @@
        return workstationWcsVO;
    }

    @Override // org.springblade.modules.cps.service.IWorkstationWcsService
    @Override 
    public List<WorkstationWcsVO> listWcsSetting() {
        List<WorkstationWcs> list = list( Wrappers.<WorkstationWcs>lambdaQuery().isNull(WorkstationWcs::getWorkstationId));
        List<WorkstationWcsVO> convert = WorkstationWcsConvert.INSTANCE.convert(list);
@@ -236,7 +226,7 @@
        return convert;
    }

    @Override // org.springblade.modules.cps.service.IWorkstationWcsService
    @Override 
    @Transactional(rollbackFor = {Exception.class})
    public List<WorkstationWcsVO> saveSetting(List<WorkstationWcsSaveVO> workstationWcsSaveVOList) {
        List<WorkstationWcs> workstationWcsList = WorkstationWcsConvert.INSTANCE.convertVOToEntity(workstationWcsSaveVOList);
@@ -269,7 +259,7 @@
        }
    }

    @Override // org.springblade.modules.cps.service.IWorkstationWcsService
    @Override 
    public Boolean deleteByWorkstationIdList(List<Long> workstationIdList) {
       remove(Wrappers.<WorkstationWcs>lambdaQuery().in(WorkstationWcs::getWorkstationId, workstationIdList));
       /*
@@ -280,7 +270,7 @@
        return true;
    }

    @Override // org.springblade.modules.cps.service.IWorkstationWcsService
    @Override 
    public List<WorkstationWcsVO> listWorkstationWcsByWorkstationId(Long workstationId) {
        List<WorkstationWcsVO> workstationWcsVOList = ((WorkstationWcsMapper) this.baseMapper).listWcs(workstationId);
        wrapperVO(workstationWcsVOList);
@@ -316,7 +306,7 @@
        });*/
    }

    @Override // org.springblade.modules.cps.service.IWorkstationWcsService
    @Override 
    public Boolean delete(List<Long> workstationWcsIdList) {
        List<WorkstationWcs> workstationWcs = listByIds(workstationWcsIdList);
        removeByIds(workstationWcsIdList);
@@ -330,7 +320,7 @@
        return null;
    }

    @Override // org.springblade.modules.cps.service.IWorkstationWcsService
    @Override 
    public void clearWorkstationParamTypeCacheByWorkstationId(List<Long> workstationIdList) {
       List<WorkstationOfMachine> workstationOfMachineList = this.workstationOfMachineService.list(Wrappers.<WorkstationOfMachine>lambdaQuery()
             .in(WorkstationOfMachine::getWorkstationId, workstationIdList));
@@ -346,7 +336,7 @@
        }
    }

    @Override // org.springblade.modules.cps.service.IWorkstationWcsService
    @Override 
    @Transactional(rollbackFor = {Exception.class})
    public List<WorkstationWcsVO> insertNew(List<WorkstationWcsSaveNewVO> workstationWcsSaveNewVOList, List<Long> workstationIdList) {
        List<WorkstationWcsSaveVO> workstationWcsSaveVOList = new ArrayList<>();
@@ -404,7 +394,7 @@
        return convert;
    }

    @Override // org.springblade.modules.cps.service.IWorkstationWcsService
    @Override 
    public String isExists(List<WorkstationWcsSaveNewVO> workstationWcsSaveNewVOList, List<Long> workstationIdList) {
        Map<Long, String> workstationIdToName = this.workstationService.listByIds(workstationIdList).stream().collect(Collectors.toMap((v0) -> {
            return v0.getId();