/*
 *    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.Location;
import com.chinaztt.mes.basic.entity.Part;
import com.chinaztt.mes.basic.mapper.LocationMapper;
import com.chinaztt.mes.basic.mapper.PartMapper;
import com.chinaztt.mes.common.numgen.NumberGenerator;
import com.chinaztt.mes.warehouse.dto.ScrapDTO;
import com.chinaztt.mes.warehouse.dto.ScrapDetailDTO;
import com.chinaztt.mes.warehouse.dto.ScrapMainDTO;
import com.chinaztt.mes.warehouse.entity.ScrapDetail;
import com.chinaztt.mes.warehouse.entity.ScrapMain;
import com.chinaztt.mes.warehouse.entity.Stock;
import com.chinaztt.mes.warehouse.mapper.ScrapDetailMapper;
import com.chinaztt.mes.warehouse.mapper.ScrapMainMapper;
import com.chinaztt.mes.warehouse.mapper.StockMapper;
import com.chinaztt.mes.warehouse.service.ScrapMainService;
import com.chinaztt.mes.warehouse.util.StockUtils;
import lombok.AllArgsConstructor;
import org.springframework.stereotype.Service;

import java.math.BigDecimal;
import java.time.LocalDateTime;
import java.util.*;
import java.util.stream.Collectors;

/**
 * 报废主表
 *
 * @author sunxl
 * @date 2020-12-07 10:07:26
 */
@AllArgsConstructor
@Service
public class ScrapMainServiceImpl extends ServiceImpl<ScrapMainMapper, ScrapMain> implements ScrapMainService {
	private NumberGenerator<ScrapMain> numberGenerator;
	private ScrapDetailMapper scrapDetailMapper;
	private StockMapper stockMapper;
	private PartMapper partMapper;
	private LocationMapper locationMapper;
	private StockUtils stockUtils;
	@Override
	public boolean fullSave(ScrapMain scrapMain) {
		scrapMain.setScrapNo(numberGenerator.generateNumberWithPrefix(ScrapMain.DIGIT,ScrapMain.PREFIX,ScrapMain::getScrapNo));
         baseMapper.insert(scrapMain);
		return true;
	}

	@Override
	public boolean fullDetailSave(ScrapDetail scrapDetail) {
		//判断是否重复
		determine(scrapDetail);
		if (scrapDetail.getLocQty().compareTo(scrapDetail.getScrapQty())==-1){
			throw new RuntimeException("库存零件报废数量超过了库存数量，请重新填写");
		}
		scrapDetail.setScrapTime(LocalDateTime.now());
		scrapDetailMapper.insert(scrapDetail);
		return false;
	}

	@Override
	public IPage<List<ScrapMainDTO>> getScrapMainPage(Page page, QueryWrapper<ScrapMainDTO> gen) {
		return baseMapper.getScrapMainPage(page,gen);
	}

	@Override
	public IPage<List<ScrapDetailDTO>> getScrapPage(Page page, QueryWrapper<ScrapDetailDTO> gen) {
		return baseMapper.getScrapPage(page,gen);
	}

	@Override
	public ScrapDetailDTO getScrapDetailById(Long id) {
		return baseMapper.getScrapDetailById(id);
	}

	@Override
	public boolean fullDelete(ScrapMainDTO scrapMainDTO) {
		if (scrapMainDTO.getPartNo() != null) {
		 ScrapDetail newScrapDetails =getScrapDetail(scrapMainDTO);
			if (newScrapDetails!=null)
			{
				scrapDetailMapper.deleteById(newScrapDetails);
			}
		}
		List<ScrapDetail> newScrapDetail = scrapDetailMapper.selectList(Wrappers.<ScrapDetail>lambdaQuery().eq(ScrapDetail::getScrapMainId,scrapMainDTO.getId()));
		if (newScrapDetail.size() == 0){
			baseMapper.deleteById(scrapMainDTO);
		}
		return true;
	}

	@Override
	public boolean submitScrapMain(List<ScrapMainDTO> scrapMainDTO) {
		for (ScrapMainDTO newScrapMainDTO:scrapMainDTO){
			if (newScrapMainDTO.getScrapQty()==null&&newScrapMainDTO.getScrapQty().compareTo(BigDecimal.ZERO)==0){
				throw new RuntimeException("报废数量为空或为0，请检查");
			}
			if (newScrapMainDTO.getScrapQty()!=null){
				ScrapDetail newScrapDetail =getScrapDetail(newScrapMainDTO);
				newScrapDetail.setStatus("已下发");
				scrapDetailMapper.updateById(newScrapDetail);
				Stock stock = stockMapper.selectOne(Wrappers.<Stock>lambdaQuery().eq(Stock::getPartId,newScrapDetail.getPartId())
						.eq(Stock::getLocationId,newScrapDetail.getLocationId()).eq(Stock::getPartBatchNo,newScrapDetail.getPartBatchNo()).eq(Stock::getSystemNo,newScrapDetail.getSystemNo()));
				stockUtils.updateById(stock.getId(),newScrapMainDTO.getScrapQty().negate(),BigDecimal.ZERO, BigDecimal.ZERO, BigDecimal.ZERO,newScrapMainDTO.getScrapNo(),"SCRAP");
			}
		}
		return false;
	}

	@Override
	public boolean updateScrapById(ScrapDetail scrapDetail) {
		if (scrapDetail.getLocQty().compareTo(scrapDetail.getScrapQty())==-1){
			throw new RuntimeException("库存零件报废数量超过了库存数量，请重新填写");
		}
		determine(scrapDetail);
		scrapDetailMapper.updateById(scrapDetail);
		return false;
	}

	@Override
	public boolean removeScrapDetailById(Long id) {
		scrapDetailMapper.deleteById(id);
		return false;
	}

	@Override
	public List<ScrapMainDTO> getPicture(QueryWrapper<ScrapMainDTO> gen) {
		List<ScrapMainDTO> scrapMainDTO= baseMapper.getPicture(gen);
		//先按类型进行分组
		Map<String,List<ScrapMainDTO>> stringListMap = scrapMainDTO.stream().collect(Collectors.groupingBy(ScrapMainDTO::getScrapType));
		List<Object> dataList = Arrays.asList( "日期", "1月", "2月","3月", "4月", "5月","6月", "7月", "8月","9月", "10月", "11月","12月");
		List<List<Object>> scrapList = new ArrayList<>();
		scrapList.add(dataList);
		if (CollectionUtil.isNotEmpty(stringListMap)){
			for(String key : stringListMap.keySet()) {
				List<Object> scrapMainList = new ArrayList<>();
				scrapMainList.add(key);
				List<ScrapMainDTO> scrapDetailList = stringListMap.get(key);
				A:for (int i = 1; i <=dataList.size()-1; i++) {
					for (int j = 0; j <scrapDetailList.size(); j++) {
						if (CollectionUtil.isNotEmpty(scrapDetailList)){
							if (dataList.get(i) == scrapDetailList.get(j).getTime()) {
								scrapMainList.add(scrapDetailList.get(j).getNumber());
								continue A;
							}
						}

					}
					scrapMainList.add(0);
				}
				scrapList.add(scrapMainList);
			}
		}
		scrapMainDTO.get(0).setScrapList(scrapList);
		return scrapMainDTO;
	}

	@Override
	public List<ScrapMainDTO> getPie(QueryWrapper<ScrapMainDTO> gen) {
		List<ScrapMainDTO> scrapMainDTO= baseMapper.getPie(gen);
		return scrapMainDTO;
	}

	@Override
	public List<ScrapDTO> getStatement(QueryWrapper<ScrapMainDTO> gen) {
		List<ScrapDTO> scrapDTOList= baseMapper.getScrapPie(gen);
		for (ScrapDTO scrapDTO:scrapDTOList) {
			List<ScrapDTO> scrapMain = baseMapper.getScrapDetail(scrapDTO.getName());
			scrapDTO.setList(scrapMain);
		}
		return scrapDTOList;
	}


	public ScrapDetail getScrapDetail(ScrapMainDTO scrapMainDTO){
		 Part part =partMapper.selectOne(Wrappers.<Part>lambdaQuery().eq(Part::getPartNo,scrapMainDTO.getPartNo()));
		 Location location =locationMapper.selectOne(Wrappers.<Location>lambdaQuery().eq(Location::getLocNo,scrapMainDTO.getLocationNo()));
		 ScrapDetail scrapDetail = scrapDetailMapper.selectOne(Wrappers.<ScrapDetail>lambdaQuery().eq(ScrapDetail::getLocationId,location.getId()).eq(ScrapDetail::getPartId,part.getId())
				 .eq(ScrapDetail::getPartBatchNo,scrapMainDTO.getPartBatchNo()).eq(ScrapDetail::getScrapMainId,scrapMainDTO.getId()));
		 return scrapDetail;
	 }
	 public void determine(ScrapDetail scrapDetail){
		 ScrapDetail scrapDetail1 = scrapDetailMapper.selectOne(Wrappers.<ScrapDetail>lambdaQuery().eq(ScrapDetail::getPartId,scrapDetail.getPartId())
				 .eq(ScrapDetail::getLocationId,scrapDetail.getLocationId()).eq(ScrapDetail::getPartBatchNo,scrapDetail.getPartBatchNo()).eq(ScrapDetail::getScrapMainId,scrapDetail.getScrapMainId()));
		 if (scrapDetail1!=null){
			 throw new RuntimeException("库存零件重复："+scrapDetail1.getPartId());
		 }
	 }
}