| | |
| | | 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; |
| | |
| | | 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 |
| | |
| | | */ |
| | | } |
| | | |
| | | @Override // org.springblade.modules.coproduction.service.IOrderWorkstationService |
| | | @Override |
| | | public void generateOrderWorkstation(List<OrderProcess> orderProcessList) { |
| | | List<OrderWorkstation> orderWorkstationList = new ArrayList<>(); |
| | | orderProcessList.forEach(orderProcess -> { |
| | |
| | | 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) |
| | |
| | | */ |
| | | } |
| | | |
| | | @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()) { |
| | |
| | | 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(); |
| | |
| | | */ |
| | | } |
| | | |
| | | @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));*/ |
| | | |
| | | } |
| | | } |