/*
 *    Copyright (c) 2018-2025, ztt All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions are met:
 *
 * Redistributions of source code must retain the above copyright notice,
 * this list of conditions and the following disclaimer.
 * Redistributions in binary form must reproduce the above copyright
 * notice, this list of conditions and the following disclaimer in the
 * documentation and/or other materials provided with the distribution.
 * Neither the name of the pig4cloud.com developer nor the names of its
 * contributors may be used to endorse or promote products derived from
 * this software without specific prior written permission.
 * Author: ztt
 */
package com.chinaztt.mes.warehouse.service.impl;

import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.chinaztt.mes.basic.entity.Part;
import com.chinaztt.mes.warehouse.dto.PalletTransportsMaterialDTO;
import com.chinaztt.mes.warehouse.entity.PalletTransports;
import com.chinaztt.mes.warehouse.entity.PalletTransportsDetail;
import com.chinaztt.mes.warehouse.entity.PalletTransportsMaterial;
import com.chinaztt.mes.warehouse.mapper.PalletTransportsDetailMapper;
import com.chinaztt.mes.warehouse.mapper.PalletTransportsMapper;
import com.chinaztt.mes.warehouse.mapper.PalletTransportsMaterialMapper;
import com.chinaztt.mes.warehouse.service.PalletTransportsDetailService;
import com.chinaztt.mes.warehouse.service.PalletTransportsMaterialService;
import com.chinaztt.mes.warehouse.state.constant.PalletTransportsState;
import com.chinaztt.mes.warehouse.state.pallettransportsdetail.PalletTransportsDetailStateStringValues;
import com.chinaztt.ztt.common.core.util.R;
import lombok.AllArgsConstructor;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Lazy;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.math.BigDecimal;
import java.util.List;
import java.util.Set;
import java.util.stream.Collectors;

/**
 * 货盘运输任务物料需求
 *
 * @author shz
 * @date 2022-05-24 17:17:25
 */
@Transactional(rollbackFor = Exception.class)
@Service
@AllArgsConstructor
public class PalletTransportsMaterialServiceImpl extends ServiceImpl<PalletTransportsMaterialMapper, PalletTransportsMaterial> implements PalletTransportsMaterialService {

	private PalletTransportsDetailMapper detailMapper;

	private PalletTransportsMapper palletTransportsMapper;


	@Override
	public IPage<PalletTransportsMaterialDTO> getPage(Page page, QueryWrapper<PalletTransportsMaterialDTO> gen) {
		return this.baseMapper.getPage(page, gen);
	}

	@Override
	public boolean fullDeleteById(Long id) {
		// 查找是否有已执行记录
		List<PalletTransportsDetail> checkList = detailMapper.selectList(Wrappers.<PalletTransportsDetail>lambdaQuery().eq(PalletTransportsDetail::getTransportsMaterialId, id).eq(PalletTransportsDetail::getState, PalletTransportsDetailStateStringValues.SUBMITTED));
		if (!checkList.isEmpty()) {
			throw new RuntimeException("有已执行记录无法删除");
		}
		PalletTransportsMaterial transportsMaterial = baseMapper.selectById(id);
		Long transportsId = transportsMaterial.getTransportsId();
		detailMapper.delete(Wrappers.<PalletTransportsDetail>lambdaQuery().eq(PalletTransportsDetail::getTransportsMaterialId, id));
		this.removeById(id);
		List<PalletTransportsMaterial> materialList = baseMapper.selectList(Wrappers.<PalletTransportsMaterial>lambdaQuery().eq(PalletTransportsMaterial::getTransportsId, transportsId));
		if(CollectionUtil.isEmpty(materialList)){
			PalletTransports palletTransports = new PalletTransports();
			palletTransports.setId(transportsId);
			palletTransports.setState(PalletTransportsState.DRAFT.getCode());
			palletTransportsMapper.updateById(palletTransports);
		}else {
			changeTransportsState(transportsId);
		}
		return true;
	}

	@Override
	public void calculateQuantity(Long id, BigDecimal quanlity, Boolean flag) {
		synchronized (String.valueOf(id).intern()) {
			PalletTransportsMaterial material = this.getById(id);
			PalletTransportsMaterial update = new PalletTransportsMaterial();
			update.setId(material.getId());
			if (flag) {
				update.setTransferQuantity(material.getTransferQuantity().add(quanlity));
				if (material.getDemandQuantity().compareTo(update.getTransferQuantity()) < 0) {
					update.setSurplusQuantity(BigDecimal.ZERO);
				} else {
					update.setSurplusQuantity(material.getDemandQuantity().subtract(update.getTransferQuantity()));
				}
			} else {
				update.setTransferQuantity(material.getTransferQuantity().subtract(quanlity));
				update.setSurplusQuantity(material.getSurplusQuantity().add(quanlity));
			}
			this.updateById(update);
		}
	}


	public void checkTransportsState(Long palletTransportsId){
		PalletTransports transports = palletTransportsMapper.selectById(palletTransportsId);
		if(PalletTransportsState.FINISHED.getCode().equals(transports.getState())){
			throw new RuntimeException("已完成的货盘运输任务不允许再添加物料需求和添加明细");
		}
	}

	@Override
	public void savePalletTransportsMaterial(PalletTransportsMaterial palletTransportsMaterial) {
		checkTransportsState(palletTransportsMaterial.getTransportsId());
		baseMapper.insert(palletTransportsMaterial);
		PalletTransports palletTransports = new PalletTransports();
		palletTransports.setId(palletTransportsMaterial.getTransportsId());
		palletTransports.setState(PalletTransportsState.PROCESSING.getCode());
		palletTransportsMapper.updateById(palletTransports);

	}



	public void changeTransportsState(Long transportsId){
		List<PalletTransportsDetail> palletTransportsDetailList = detailMapper.selectList(Wrappers.<PalletTransportsDetail>lambdaQuery()
				.eq(PalletTransportsDetail::getTransportsId, transportsId));
		boolean present = palletTransportsDetailList.stream()
				.allMatch(a->PalletTransportsDetailStateStringValues.SUBMITTED.equals(a.getState()));
		List<PalletTransportsMaterial> palletTransportsMaterialList = baseMapper.selectList(Wrappers.<PalletTransportsMaterial>lambdaQuery()
				.eq(PalletTransportsMaterial::getTransportsId, transportsId));
		Set<Long> materialIdList = palletTransportsMaterialList.stream().map(PalletTransportsMaterial::getId).collect(Collectors.toSet());
		Set<Long> detailMaterialIdList = palletTransportsDetailList.stream().map(PalletTransportsDetail::getTransportsMaterialId).collect(Collectors.toSet());
		Boolean flag = false;
		if(materialIdList.size()==detailMaterialIdList.size()){
			if(materialIdList.containsAll(detailMaterialIdList)){
				flag = true;
			}
		}
		if(present && flag){
			PalletTransports palletTransports = new PalletTransports();
			palletTransports.setId(transportsId);
			palletTransports.setState(PalletTransportsState.FINISHED.getCode());
			palletTransportsMapper.updateById(palletTransports);
		}
	}
}