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 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.dto.ResultByStartDTO;
import com.qianwen.smartman.modules.coproduction.entity.OrderProcess;
import com.qianwen.smartman.modules.coproduction.entity.OrderReportRecord;
import com.qianwen.smartman.modules.coproduction.entity.OrderWorkstation;
import com.qianwen.smartman.modules.coproduction.enums.CoProductionEnum;
import com.qianwen.smartman.modules.coproduction.enums.WorkstationStatusEnum;
import com.qianwen.smartman.modules.coproduction.mapper.OrderWorkstationMapper;
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
    public List<OrderWorkstation> getWorkstationInProcess(Set<Long> workstationIdList) {
        return  this.baseMapper.getWorkstationInProcess(workstationIdList);
    }

    @Override // org.springblade.modules.coproduction.service.IOrderWorkstationService
    public void updateOrderWorkstationForStart(Map<Long, OrderReportRecord> orderReportRecordMap, ResultByStartDTO resultByStartDTO, Map<Long, OrderProcessStartWorkstationVO> workstationVoMap) {
		resultByStartDTO.getCanStartWorkstationIdList().forEach(i -> update(
				Wrappers
						.<OrderWorkstation>lambdaUpdate().eq(OrderWorkstation::getWorkstationId, i).eq(OrderWorkstation::getProcessId,
								resultByStartDTO.getWorkstationAndOrderProcessIdMap().get(i))
						.set(OrderWorkstation::getProducerId,
								workstationVoMap.get(i).getProducerId())
						.set(OrderWorkstation::getProducerCode,
								workstationVoMap.get(i).getProducerCode())
						.set(OrderWorkstation::getProducerName,
								workstationVoMap.get(i).getProducerName())
						.set(OrderWorkstation::getWorkstationStatus, WorkstationStatusEnum.started.getCode())
						.set(OrderWorkstation::getCurrentRecordId,
								orderReportRecordMap.get(i).getId())));
		/*
        resultByStartDTO.getCanStartWorkstationIdList().forEach(i -> {
            update((Wrapper) ((LambdaUpdateWrapper) ((LambdaUpdateWrapper) ((LambdaUpdateWrapper) ((LambdaUpdateWrapper) ((LambdaUpdateWrapper) ((LambdaUpdateWrapper) Wrappers.lambdaUpdate().eq((v0) -> {
                return v0.getWorkstationId();
            }, i)).eq((v0) -> {
                return v0.getProcessId();
            }, resultByStartDTO.getWorkstationAndOrderProcessIdMap().get(i))).set((v0) -> {
                return v0.getProducerId();
            }, ((OrderProcessStartWorkstationVO) workstationVoMap.get(i)).getProducerId())).set((v0) -> {
                return v0.getProducerCode();
            }, ((OrderProcessStartWorkstationVO) workstationVoMap.get(i)).getProducerCode())).set((v0) -> {
                return v0.getProducerName();
            }, ((OrderProcessStartWorkstationVO) workstationVoMap.get(i)).getProducerName())).set((v0) -> {
                return v0.getWorkstationStatus();
            }, WorkstationStatusEnum.started.getCode())).set((v0) -> {
                return v0.getCurrentRecordId();
            }, ((OrderReportRecord) orderReportRecordMap.get(i)).getId()));
            
        });
        */
    }

    @Override // org.springblade.modules.coproduction.service.IOrderWorkstationService
    public void generateOrderWorkstation(List<OrderProcess> orderProcessList) {
        List<OrderWorkstation> orderWorkstationList = new ArrayList<>();
        orderProcessList.forEach(orderProcess -> {
            String workstationIds = orderProcess.getWorkstationId();
            if (Func.isEmpty(workstationIds)) {
                OrderWorkstation orderWorkstation = new OrderWorkstation();
                orderWorkstation.setPlanId(orderProcess.getPlanId());
                orderWorkstation.setOrderId(orderProcess.getOrderId());
                orderWorkstation.setProcessId(orderProcess.getId());
                orderWorkstationList.add(orderWorkstation);
                return;
            }
            String[] workstationIdSplit = workstationIds.split(",");
            String[] workstationNameSplit = orderProcess.getWorkstationName().split(",");
            for (int i = 0; i < workstationIdSplit.length; i++) {
                OrderWorkstation orderWorkstation2 = new OrderWorkstation();
                orderWorkstation2.setPlanId(orderProcess.getPlanId());
                orderWorkstation2.setOrderId(orderProcess.getOrderId());
                orderWorkstation2.setProcessId(orderProcess.getId());
                Long workstationId = Long.valueOf(workstationIdSplit[i]);
                String workstationName = workstationNameSplit[i];
                orderWorkstation2.setWorkstationId(workstationId);
                orderWorkstation2.setWorkstationName(workstationName);
                orderWorkstation2.setWorkstationStatus(WorkstationStatusEnum.UNDRESSED.getCode());
                orderWorkstationList.add(orderWorkstation2);
            }
        });
        saveBatch(orderWorkstationList);
    }

    @Override // org.springblade.modules.coproduction.service.IOrderWorkstationService
    public void updateOrderWorkstationForStartMain(Long orderProcessId, Long recordId) {
    	update(Wrappers.<OrderWorkstation>lambdaUpdate()
    	        .eq(OrderWorkstation::getProcessId, orderProcessId)
    	        .set(OrderWorkstation::getWorkstationStatus, WorkstationStatusEnum.started.getCode())
    	        .set(OrderWorkstation::getCurrentRecordId, recordId));
		/*
		 * update((Wrapper) ((LambdaUpdateWrapper) ((LambdaUpdateWrapper)
		 * Wrappers.lambdaUpdate().eq((v0) -> { return v0.getProcessId(); },
		 * orderProcessId)).set((v0) -> { return v0.getWorkstationStatus(); },
		 * WorkstationStatusEnum.started.getCode())).set((v0) -> { return
		 * v0.getCurrentRecordId(); }, recordId));
		 */
    }

    @Override // org.springblade.modules.coproduction.service.IOrderWorkstationService
    public Boolean checkProcessHaveAssign(Long orderProcessId) {
        Integer count = ((OrderWorkstationMapper) this.baseMapper).checkProcessHaveAssign(orderProcessId);
        if (count.intValue() > Integer.valueOf("0").intValue()) {
            return Boolean.TRUE;
        }
        return Boolean.FALSE;
    }

    @Override // org.springblade.modules.coproduction.service.IOrderWorkstationService
    @Transactional(rollbackFor = {Exception.class})
    public void reportWorkstation(OrderProcessReportWorkDTO workDTO, OrderWorkstation orderWorkstation) {
        Integer qualifyNum = workDTO.getQualifyNum();
        Integer scrappedNum = workDTO.getScrappedNum();
        Integer oldQualifyNum = Integer.valueOf(orderWorkstation.getQualifyNum() == null ? 0 : orderWorkstation.getQualifyNum().intValue());
        Integer oldScrappedNum = Integer.valueOf(orderWorkstation.getScrappedNum() == null ? 0 : orderWorkstation.getScrappedNum().intValue());
        Integer newQualifyNum = Integer.valueOf(qualifyNum.intValue() + oldQualifyNum.intValue());
        Integer newScrappedNum = Integer.valueOf(scrappedNum.intValue() + oldScrappedNum.intValue());
        
        update(Wrappers.<OrderWorkstation>lambdaUpdate()
                .eq(OrderWorkstation::getId, orderWorkstation.getId())
                .set(OrderWorkstation::getQualifyNum, newQualifyNum)
                .set(OrderWorkstation::getScrappedNum, newScrappedNum)
                .set(OrderWorkstation::getWorkstationStatus, CoProductionEnum.WorkstationStatus.NO.getCode()));
        
        /*
        update((Wrapper) ((LambdaUpdateWrapper) ((LambdaUpdateWrapper) ((LambdaUpdateWrapper) Wrappers.lambdaUpdate().eq((v0) -> {
            return v0.getId();
        }, orderWorkstation.getId())).set((v0) -> {
            return v0.getQualifyNum();
        }, newQualifyNum)).set((v0) -> {
            return v0.getScrappedNum();
        }, newScrappedNum)).set((v0) -> {
            return v0.getWorkstationStatus();
        }, CoProductionEnum.WorkstationStatus.NO.getCode()));
        */
    }

    @Override // org.springblade.modules.coproduction.service.IOrderWorkstationService
    public List<WorkstationSingleVO> getWorkstationCanStart(Long orderProcessId) {
        List<WorkstationSingleVO> result = ((OrderWorkstationMapper) this.baseMapper).getWorkstationCanStart(orderProcessId);
        if (Func.isEmpty(result)) {
            return new ArrayList();
        }
        return result;
    }

    @Override // org.springblade.modules.coproduction.service.IOrderWorkstationService
    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
    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));*/
    }
}