用时分析代码整理+注释整理

yangys

2024-04-28 258a769f6790f832d1c67839d59be04a118767e5

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

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

import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import java.lang.invoke.SerializedLambda;
import java.util.List;
import java.util.stream.Collectors;
import com.qianwen.smartman.common.cache.RegionCache;
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 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.utils.Lambda;
import com.qianwen.smartman.common.utils.MessageUtils;
import com.qianwen.smartman.modules.cps.convert.WorkstationWorkbenchConvert;
import com.qianwen.smartman.modules.cps.entity.WorkstationWorkbench;
import com.qianwen.smartman.modules.cps.mapper.WorkstationWorkbenchMapper;
@@ -30,9 +30,6 @@
import com.qianwen.smartman.modules.trace.entity.TraceRelatedWorkstation;
import com.qianwen.smartman.modules.trace.service.ITraceFlowSettingsService;
import com.qianwen.smartman.modules.trace.service.ITraceRelatedWorkstationService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Lazy;
import org.springframework.stereotype.Service;

@Service
public class WorkstationWorkbenchServiceImpl extends BaseServiceImpl<WorkstationWorkbenchMapper, WorkstationWorkbench> implements IWorkstationWorkbenchService {
@@ -51,7 +48,7 @@
    private final Integer DEFAULT = 1;


    @Override // org.springblade.modules.cps.service.IWorkstationWorkbenchService
    @Override
    public Boolean saveWorkstationWorkbench(WorkstationWorkbenchVO vo) {
       WorkstationWorkbench workbench = (WorkstationWorkbench)getOne(Wrappers.<WorkstationWorkbench>query().lambda()
               .eq(WorkstationWorkbench::getWorkstationId, vo.getWorkstationId())
@@ -71,7 +68,7 @@
        throw new ServiceException(MessageUtils.message("work.station.work.bench.name.already.exist", new Object[0]));
    }

    @Override // org.springblade.modules.cps.service.IWorkstationWorkbenchService
    @Override
    public MachineInformationVO listWorkstationWorkbench(Long workstationId) {
        TransferDirectory transferDirectory;
        MachineInformationVO machineInformationVO = new MachineInformationVO();
@@ -96,17 +93,15 @@
        machineInformationVO.setDeviceType(workstationVO.getDeviceType());
        machineInformationVO.setWorkstationName(workstationVO.getName());
        machineInformationVO.setProperties(workstationVO.getProperties());
        DncWsRelationTd relationTd = (DncWsRelationTd) this.dncWsRelationTdService.getOne(Lambda.eq((v0) -> {
            return v0.getWorkstationId();
        }, workstationId));
        DncWsRelationTd relationTd = (DncWsRelationTd) this.dncWsRelationTdService.getOne(Lambda.eq(DncWsRelationTd::getWorkstationId, workstationId));
        machineInformationVO.setTransmissionMode(workstationVO.getTransmissionMethod());
        if (Func.isNotEmpty(relationTd) && (transferDirectory = (TransferDirectory) this.transferDirectoryService.getById(relationTd.getTransferDirectorId())) != null) {
        if (Func.isNotEmpty(relationTd) && (transferDirectory = this.transferDirectoryService.getById(relationTd.getTransferDirectorId())) != null) {
            machineInformationVO.setFtpCatalogue(transferDirectory.getName());
        }
        return machineInformationVO;
    }

    @Override // org.springblade.modules.cps.service.IWorkstationWorkbenchService
    @Override
    public Boolean deleteWorkstationWorkbench(WorkstationWorkbenchVO vo) {
        if (vo.getWorkbenchDefault().equals(this.DEFAULT)) {
            throw new ServiceException(MessageUtils.message("work.station.default.work.bench.not.delete", new Object[0]));
@@ -151,7 +146,7 @@
        return Boolean.valueOf(remove);
    }

    @Override // org.springblade.modules.cps.service.IWorkstationWorkbenchService
    @Override 
    public Boolean updateWorkstationWorkbench(WorkstationWorkbenchVO vo) {
       WorkstationWorkbench workbench = getOne(Wrappers.<WorkstationWorkbench>query().lambda()
               .eq(WorkstationWorkbench::getWorkstationId, vo.getWorkstationId())
@@ -181,7 +176,7 @@
    public List<WorkstationOfWorkbenchVO> listByGroupId(Long groupId, Long settingsId, String keyWord) {
        List<Long> groupIds = this.workstationService.productionLineList(groupId);
        if (Func.isEmpty(groupId)) {
            return ((WorkstationWorkbenchMapper) this.baseMapper).listByGroupId(groupIds, keyWord);
            return this.baseMapper.listByGroupId(groupIds, keyWord);
        }
        List<Long> settingsIdList = this.traceFlowSettingsService.list(Wrappers.<TraceFlowSettings>lambdaQuery()
              .eq(TraceFlowSettings::getWorkstationGroupId, groupId)
@@ -196,7 +191,7 @@
            return v0.getId();
        }).collect(Collectors.toList());*/
        if (Func.isEmpty(settingsIdList)) {
            return ((WorkstationWorkbenchMapper) this.baseMapper).listByGroupId(groupIds, keyWord);
            return this.baseMapper.listByGroupId(groupIds, keyWord);
        }
        List<Long> workstationIdList = this.traceRelatedWorkstationService.list(Wrappers.<TraceRelatedWorkstation>lambdaQuery()
              .in(TraceRelatedWorkstation::getTraceFlowSettingId, settingsIdList))