/*
 *    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.production.service.impl;

import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
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.mould.util.MouldUtil;
import com.chinaztt.mes.plan.entity.MoRoutingOperation;
import com.chinaztt.mes.plan.mapper.MoRoutingOperationMapper;
import com.chinaztt.mes.production.dto.MouldRegisterDTO;
import com.chinaztt.mes.production.dto.MouldUseRecordDTO;
import com.chinaztt.mes.production.dto.mould.InsertLifeDTO;
import com.chinaztt.mes.production.entity.*;
import com.chinaztt.mes.production.mapper.MouldRegisterMapper;
import com.chinaztt.mes.production.mapper.MouldUseRecordMapper;
import com.chinaztt.mes.production.mapper.ProductOutputMapper;
import com.chinaztt.mes.production.mapper.ProductStepMapper;
import com.chinaztt.mes.production.service.MouldUseRecordService;
import com.chinaztt.mes.technology.entity.RoutingOperation;
import com.chinaztt.mes.technology.mapper.RoutingOperationMapper;
import com.chinaztt.ztt.common.security.util.SecurityUtils;
import lombok.AllArgsConstructor;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.math.BigDecimal;
import java.text.SimpleDateFormat;
import java.util.Collections;
import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;

/**
 * 模具使用记录表
 *
 * @author cxf
 * @date 2021-10-25 13:07:10
 */
@Service
@AllArgsConstructor
@Transactional(rollbackFor = Exception.class)
public class MouldUseRecordServiceImpl extends ServiceImpl<MouldUseRecordMapper, MouldUseRecord> implements MouldUseRecordService {

	private ProductOutputMapper productOutputMapper;
	private MouldRegisterMapper mouldRegisterMapper;
	private ProductStepMapper productStepMapper;
	private MoRoutingOperationMapper routingOperationMapper;

	private MouldUtil mouldUtil;

	@Override
	public IPage<MouldUseRecordDTO> getMouldUseRecordPage(Page page, QueryWrapper<MouldUseRecordDTO> gen) {
		return baseMapper.getMouldUseRecordPage(page,gen);
	}

	@Override
	public Boolean insertMouldLife(ProductMain productMain) {
		// 找出登记的模具
		List<MouldRegisterDTO> registerList = mouldRegisterMapper.selectByWorkstationId(productMain.getWorkstationId());
		if (CollectionUtils.isEmpty(registerList)) {
			return false;
		}
		for (MouldRegisterDTO register:registerList) {
			// 调用模具消耗接口参数
			InsertLifeDTO dto = new InsertLifeDTO();
			dto.setMouldCode(register.getMouldCode());
			dto.setSerialNumber(productMain.getProductNo());
			dto.setProcedureNumber(register.getOperationName());
			dto.setMachineNumber(register.getWorkstationNo());
			dto.setBuildMaker(SecurityUtils.getUser().getUsername());
			dto.setProductSpec(register.getPartNo());
			dto.setProductionDate(new SimpleDateFormat("yyyy-MM-dd").format(new Date()));

			BigDecimal total = BigDecimal.ZERO;

			// 找出该报工所有产出
			List<ProductOutput> outputList = productOutputMapper.selectList(Wrappers.<ProductOutput>lambdaQuery()
					.eq(ProductOutput::getProductMainId, productMain.getId()));

			// 判断模具登记类型
			// 工序直接按产出计算消耗
			if (register.getType() == MouldRegister.TYPE_OPERATION) {
				MoRoutingOperation operation = routingOperationMapper.findByProductMainId(productMain.getId());
				if (!operation.getOperationId().equals(register.getOperationId())) {
					return false;
				}

				total = outputList.stream().map(ProductOutput::getProductQty).reduce(BigDecimal.ZERO, BigDecimal::add);
				dto.setLifeValue(total.multiply(register.getLifeConversionFactor()));
			} else {
				// 找出工单工步数据
				List<ProductStep> productSteps = productStepMapper.selectList(Wrappers.<ProductStep>lambdaQuery()
						.eq(ProductStep::getProductMainId, productMain.getId()).eq(ProductStep::getStepId, register.getStepId()));
				if (productSteps.isEmpty()) {
					return false;
				}
				total = productSteps.stream().map(ProductStep::getNumber).reduce(BigDecimal.ZERO, BigDecimal::add);
				dto.setLifeValue(total.multiply(register.getLifeConversionFactor()));
			}

			MouldUseRecord record = new MouldUseRecordDTO();
			record.setMouldRegisterId(register.getId());
			record.setProductMainId(productMain.getId());
			record.setOperationTaskId(productMain.getOperationTaskId());
			record.setOutput(total);
			record.setUsageAmount(dto.getLifeValue());
			record.setProductNo(productMain.getProductNo());
			record.setStatus(MouldUseRecord.STATE_SUBMITTED);
			record.setWorkstationId(register.getWorkstationId());
			if (CollectionUtils.isNotEmpty(outputList)) {
				record.setBatchNo(outputList.get(0).getOutBatchNo());
			}
			record.insert();
			mouldUtil.insertTempLifeRecord(JSON.toJSONString(dto));
		}
		return true;
	}

	@Override
	public Boolean clearMouldLife(ProductMain productMain) {
		// 找出登记的模具
		List<MouldRegisterDTO> registerList = mouldRegisterMapper.selectByWorkstationId(productMain.getWorkstationId());
		if (CollectionUtils.isEmpty(registerList)) {
			return false;
		}
		List<MouldUseRecord> recordList = this.list(Wrappers.<MouldUseRecord>lambdaQuery().eq(MouldUseRecord::getProductMainId, productMain.getId()));
		if (CollectionUtils.isEmpty(recordList)) {
			return false;
		}
		// 清除模具使用记录表
		List<Long> recordIdList = recordList.stream().map(MouldUseRecord::getId).collect(Collectors.toList());
		baseMapper.deleteBatchIds(recordIdList);

		// 调用模具消耗接口参数
		for (MouldRegisterDTO register: registerList) {
			InsertLifeDTO dto = new InsertLifeDTO();
			dto.setMouldCode(register.getMouldCode());
			dto.setSerialNumber(productMain.getProductNo());
			dto.setProcedureNumber(register.getOperationName());
			dto.setMachineNumber(register.getWorkstationNo());
			dto.setBuildMaker(SecurityUtils.getUser().getUsername());
			dto.setProductSpec(register.getPartNo());
			dto.setLifeValue(BigDecimal.ZERO);
			mouldUtil.insertTempLifeRecord(JSON.toJSONString(dto));
		}
		return true;
	}
}