yangys
2024-05-09 60e317f7782c718d28920060fd686d2092c99c1e
smart-man-boot/src/main/java/com/qianwen/smartman/modules/coproduction/service/impl/OrderWorkstationServiceImpl.java
@@ -1,14 +1,14 @@
package com.qianwen.smartman.modules.coproduction.service.impl;
import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import java.lang.invoke.SerializedLambda;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.Set;
import com.qianwen.smartman.common.cache.RegionCache;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.qianwen.core.mp.base.BaseServiceImpl;
import com.qianwen.core.tool.utils.Func;
import com.qianwen.smartman.modules.coproduction.dto.OrderProcessReportWorkDTO;
@@ -22,19 +22,17 @@
import com.qianwen.smartman.modules.coproduction.service.IOrderWorkstationService;
import com.qianwen.smartman.modules.coproduction.vo.OrderProcessStartWorkstationVO;
import com.qianwen.smartman.modules.cps.vo.WorkstationSingleVO;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
@Service
public class OrderWorkstationServiceImpl extends BaseServiceImpl<OrderWorkstationMapper, OrderWorkstation> implements IOrderWorkstationService {
    
    @Override // org.springblade.modules.coproduction.service.IOrderWorkstationService
    @Override
    public List<OrderWorkstation> getWorkstationInProcess(Set<Long> workstationIdList) {
        return  this.baseMapper.getWorkstationInProcess(workstationIdList);
    }
    @Override // org.springblade.modules.coproduction.service.IOrderWorkstationService
    @Override
    public void updateOrderWorkstationForStart(Map<Long, OrderReportRecord> orderReportRecordMap, ResultByStartDTO resultByStartDTO, Map<Long, OrderProcessStartWorkstationVO> workstationVoMap) {
      resultByStartDTO.getCanStartWorkstationIdList().forEach(i -> update(
            Wrappers
@@ -71,7 +69,7 @@
        */
    }
    @Override // org.springblade.modules.coproduction.service.IOrderWorkstationService
    @Override
    public void generateOrderWorkstation(List<OrderProcess> orderProcessList) {
        List<OrderWorkstation> orderWorkstationList = new ArrayList<>();
        orderProcessList.forEach(orderProcess -> {
@@ -102,7 +100,7 @@
        saveBatch(orderWorkstationList);
    }
    @Override // org.springblade.modules.coproduction.service.IOrderWorkstationService
    @Override
    public void updateOrderWorkstationForStartMain(Long orderProcessId, Long recordId) {
       update(Wrappers.<OrderWorkstation>lambdaUpdate()
               .eq(OrderWorkstation::getProcessId, orderProcessId)
@@ -117,7 +115,7 @@
       */
    }
    @Override // org.springblade.modules.coproduction.service.IOrderWorkstationService
    @Override
    public Boolean checkProcessHaveAssign(Long orderProcessId) {
        Integer count = ((OrderWorkstationMapper) this.baseMapper).checkProcessHaveAssign(orderProcessId);
        if (count.intValue() > Integer.valueOf("0").intValue()) {
@@ -126,7 +124,7 @@
        return Boolean.FALSE;
    }
    @Override // org.springblade.modules.coproduction.service.IOrderWorkstationService
    @Override
    @Transactional(rollbackFor = {Exception.class})
    public void reportWorkstation(OrderProcessReportWorkDTO workDTO, OrderWorkstation orderWorkstation) {
        Integer qualifyNum = workDTO.getQualifyNum();
@@ -155,28 +153,25 @@
        */
    }
    @Override // org.springblade.modules.coproduction.service.IOrderWorkstationService
    @Override
    public List<WorkstationSingleVO> getWorkstationCanStart(Long orderProcessId) {
        List<WorkstationSingleVO> result = ((OrderWorkstationMapper) this.baseMapper).getWorkstationCanStart(orderProcessId);
        if (Func.isEmpty(result)) {
            return new ArrayList();
            return new ArrayList<>();
        }
        return result;
    }
    @Override // org.springblade.modules.coproduction.service.IOrderWorkstationService
    @Override
    public OrderWorkstation buildWorkstation(OrderProcessReportWorkDTO reportWorkDTO, OrderWorkstation orderWorkstation) {
        orderWorkstation.setQualifyNum(Integer.valueOf(reportWorkDTO.getQualifyNum().intValue() + orderWorkstation.getQualifyNum().intValue())).setScrappedNum(Integer.valueOf(reportWorkDTO.getScrappedNum().intValue() + orderWorkstation.getScrappedNum().intValue())).setWorkstationStatus(CoProductionEnum.WorkstationStatus.NO.getCode()).setCurrentRecordId(null);
        return orderWorkstation;
    }
    @Override // org.springblade.modules.coproduction.service.IOrderWorkstationService
    @Override
    public List<OrderWorkstation> getWorkstationByProcessList(List<Long> orderProcessIdList) {
       return list(Wrappers.<OrderWorkstation>lambdaQuery()
               .in(OrderWorkstation::getProcessId, orderProcessIdList));
       /*
        return list((Wrapper) Wrappers.lambdaQuery().in((v0) -> {
            return v0.getProcessId();
        }, orderProcessIdList));*/
    }
}