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

yangys

2024-04-28 258a769f6790f832d1c67839d59be04a118767e5

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

@@ -102,7 +102,6 @@
import cn.hutool.core.util.StrUtil;

@Service
/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/cps/service/impl/MachineServiceImpl.class */
public class MachineServiceImpl extends BaseServiceImpl<MachineMapper, Machine> implements IMachineService {
    private static final Logger log = LoggerFactory.getLogger(MachineServiceImpl.class);
    private static final Pattern NUMBER = Pattern.compile("[1-9]\\d*.\\d*|0\\.\\d*[1-9]\\d*");
@@ -132,7 +131,7 @@
    private IEmployeeService employeeService;


    @Override // org.springblade.modules.cps.service.IMachineService
    @Override
    @Transactional(rollbackFor = {Exception.class})
    public MachineVO insert(MachineVO machineVO) {
        checkMachine(machineVO.id, machineVO.getMachineCode());
@@ -145,7 +144,7 @@
        return MachineConvert.INSTANCE.convert(machine);
    }

    @Override // org.springblade.modules.cps.service.IMachineService
    @Override
    public Boolean changeCollectSwitch(Long workstationId, Integer collectSwitch) {
        ((MachineMapper) this.baseMapper).changeCollectSwitch(workstationId, collectSwitch, AuthUtil.getTenantId());
        if (0 == collectSwitch.intValue()) {
@@ -157,7 +156,7 @@
        return true;
    }

    @Override // org.springblade.modules.cps.service.IMachineService
    @Override
    public List<WorkstationWcsDTO> getWorkstationWcsByMachineId(Long machineId, String paramName) {
       List<WorkstationOfMachine> workstationOfMachineList = this.workstationOfMachineService.list(Wrappers.<WorkstationOfMachine>lambdaQuery().eq(WorkstationOfMachine::getMachineId, machineId));
       
@@ -168,7 +167,7 @@
        return WorkstationWcsConvert.INSTANCE.convertToDTOList(workstationWcsList);
    }

    @Override // org.springblade.modules.cps.service.IMachineService
    @Override
    public Boolean updateBrand(Long id, String brand) {
        Machine machine = (Machine) getById(id);
        machine.setBrand(brand);
@@ -180,7 +179,7 @@
        return Boolean.valueOf(updateById);
    }

    @Override // org.springblade.modules.cps.service.IMachineService
    @Override
    public MachineDetailVO detailMachine(Long id) {
        MachineDetailVO machineDetailVO = ((MachineMapper) this.baseMapper).selectMachineDetail(id);
        if (Func.isNotEmpty(machineDetailVO)) {
@@ -213,7 +212,7 @@
        return machineDetailVO;
    }

    @Override // org.springblade.modules.cps.service.IMachineService
    @Override
    @Transactional(rollbackFor = {Exception.class})
    public Machine createMachine(MachineSubmitVO machineSubmitVO) {
        String pinCode = machineSubmitVO.getPinCode();
@@ -279,7 +278,7 @@
        }
    }

    @Override // org.springblade.modules.cps.service.IMachineService
    @Override
    public IPage<MachineListVO> pageMachine(MachineSelectVO machineSelectVO, Query query) {
        String machineName = machineSelectVO.getMachineName();
        String machineCode = machineSelectVO.getMachineCode();
@@ -295,7 +294,7 @@
        return page;
    }

    @Override // org.springblade.modules.cps.service.IMachineService
    @Override
    @Transactional(rollbackFor = {Exception.class})
    public Boolean updateMachine(MachineUpdateVO vo) {
        Long id = vo.getId();
@@ -337,7 +336,7 @@
        return Boolean.valueOf(updateById);
    }

    @Override // org.springblade.modules.cps.service.IMachineService
    @Override
    public void renewMachineRepairStatus(Long machineId, Integer maintenanceStatus) {
       Machine machine = (Machine)getOne(new QueryWrapper<Machine>().lambda().eq(Machine::getId, machineId));
     
@@ -347,7 +346,7 @@
        }
    }

    @Override // org.springblade.modules.cps.service.IMachineService
    @Override
    public void updateMachineRepairPriority(Long deviceId, List<RepairRecord> toBeConfirmedRecordList, List<RepairApply> inMaintenanceApplyList, List<RepairApply> toBeRepairedApplyList) {
        if (Func.isNotEmpty(toBeConfirmedRecordList)) {
            renewMachineRepairStatus(deviceId, Integer.valueOf(DeviceRepairStatusEnum.TO_BE_CONFIRM.getType()));
@@ -360,7 +359,7 @@
        }
    }

    @Override // org.springblade.modules.cps.service.IMachineService
    @Override
    public void renewMachineRepairTime(Long deviceId) {
        Machine machine = (Machine) getById(deviceId);
        if (machine != null) {
@@ -369,7 +368,7 @@
        }
    }

    @Override // org.springblade.modules.cps.service.IMachineService
    @Override
    public void createRepairApplyUpdateMachine(Long deviceId, Integer maintenanceStatus) {
        Machine machine = (Machine) getById(deviceId);
        if (machine != null) {
@@ -382,7 +381,7 @@
        }
    }

    @Override // org.springblade.modules.cps.service.IMachineService
    @Override
    public void implementRepairApply(Long deviceId, Integer maintenanceStatus) {
        Machine machine = (Machine) getById(deviceId);
        if (Func.isNull(machine.getRepairStatus())) {
@@ -393,7 +392,7 @@
        }
    }

    @Override // org.springblade.modules.cps.service.IMachineService
    @Override
    public void updateDeviceMaintainStatus(Long deviceId, Integer status, Long planId, LocalDateTime nextMaintainTime) {
        List<MaintainPlan> checkList = checkExistPlanStatus(deviceId, null);
        List<MaintainPlan> checkTimeList = checkList.stream().sorted(Comparator.comparing((v0) -> {
@@ -414,7 +413,7 @@
        updateDeviceMaintain(deviceMaintainInDTO);
    }

    @Override // org.springblade.modules.cps.service.IMachineService
    @Override
    public void updateDeviceMaintain(DeviceMaintainInDTO deviceMaintainInDTO) {
        Machine one = (Machine) getById(deviceMaintainInDTO.getDeviceId());
        if (one == null) {
@@ -426,7 +425,7 @@
        updateById(one);
    }

    @Override // org.springblade.modules.cps.service.IMachineService
    @Override
    public void updateDeviceMaintainStatus(Long deviceId, Long planId, LocalDateTime lastMaintainTime) {
        List<MaintainPlan> checkList = checkExistPlanStatus(deviceId, null);
        List<MaintainPlan> checkTimeList =  checkList.stream().sorted(Comparator.comparing((v0) -> {
@@ -450,17 +449,17 @@
        updateDeviceMaintain(deviceMaintainInDTO);
    }

    @Override // org.springblade.modules.cps.service.IMachineService
    @Override
    public List<DeviceSimpleDTO> deviceListByDeviceTypeId(Long deviceTypeId) {
        return ((MachineMapper) this.baseMapper).deviceListByDeviceTypeId(deviceTypeId);
    }

    @Override // org.springblade.modules.cps.service.IMachineService
    @Override
    public List<DeviceSimpleDTO> deviceListByDeviceIdList(List<Long> deviceIdList) {
        return ((MachineMapper) this.baseMapper).deviceListByDeviceIdList(deviceIdList);
    }

    @Override // org.springblade.modules.cps.service.IMachineService
    @Override
    public BladeFile exportMachine(MachineSelectVO vo) {
        List<MachineDetailVO> vos = ((MachineMapper) this.baseMapper).listMachineDetail(vo.getMachineName(), vo.getMachineCode(), vo.getMachineTypeId(), vo.getGroupId(), CommonGroupConstant.ALL_MACHINE_ID, vo.getStatus());
        List<MachineDetailVO> list = vos.stream().peek(c -> {
@@ -474,7 +473,7 @@
        return this.ossBuilder.tempTemplate().putFile(multipartFile.getOriginalFilename(), multipartFile);
    }

    @Override // org.springblade.modules.cps.service.IMachineService
    @Override
    @Transactional(rollbackFor = {Exception.class})
    public BladeFile importMachine(MultipartFile file) {
        List<MachineImport> rawData = ExcelUtil.read(file, 0, 2, MachineImport.class);
@@ -676,7 +675,7 @@
        });
    }

    @Override // org.springblade.modules.cps.service.IMachineService
    @Override
    @Transactional(rollbackFor = {Exception.class})
    public Boolean delete(IdsVO vo, Integer type) {
        if (StatusType.REMOVE.getType().equals(type)) {
@@ -694,7 +693,7 @@
        return Boolean.valueOf(changeStatus(Func.toLongList(vo.getIds()), CommonConstant.DEACTIVATE));
    }

    @Override // org.springblade.modules.cps.service.IMachineService
    @Override
    public List<HmiDeviceVO> getHmiWorkstation(String machineId) {
        List<HmiDeviceVO> hmiDeviceVOList = new ArrayList<>();
        Machine machine = (Machine) getById(machineId);
@@ -726,12 +725,12 @@
        return hmiDeviceVOList;
    }

    @Override // org.springblade.modules.cps.service.IMachineService
    @Override
    public List<MachineExtDTO> getMachineByWorkStation(List<Long> workstationIds) {
        return ((MachineMapper) this.baseMapper).getMachineByWorkStation(workstationIds);
    }

    @Override // org.springblade.modules.cps.service.IMachineService
    @Override
    public String queryDateTypeState(Long workstationId) {
        return ((MachineMapper) this.baseMapper).queryDateTypeState(WcsDataTypeEnums.WcsDataType.STATE.getCode(), workstationId);
    }
@@ -916,7 +915,7 @@
        return false;
    }

    @Override // org.springblade.modules.cps.service.IMachineService
    @Override
    public MachineDetailVO detailByCode(String machineCode) {
        MachineDetailVO machineDetailVO = ((MachineMapper) this.baseMapper).selectMachineDetailByCode(machineCode);
        if (Func.isNotEmpty(machineDetailVO)) {
@@ -940,7 +939,7 @@
        return machineDetailVO;
    }

    @Override // org.springblade.modules.cps.service.IMachineService
    @Override
    public IPage<MachineListVO> pageMachineByParam(MachineSelectVO machineSelectVO, Query query) {
        IPage<MachineListVO> page = ((MachineMapper) this.baseMapper).pageMachineByParam(Condition.getPage(query), machineSelectVO);
        List<MachineListVO> records = page.getRecords();
@@ -951,12 +950,12 @@
        return page;
    }

    @Override // org.springblade.modules.cps.service.IMachineService
    @Override
    public List<MachineVO> listNoBand() {
        return ((MachineMapper) this.baseMapper).listNoBand();
    }

    @Override // org.springblade.modules.cps.service.IMachineService
    @Override
    public List<MachineVO> listHaveBand() {
        return ((MachineMapper) this.baseMapper).listHaveBand();
    }