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


import cn.hutool.core.collection.CollectionUtil;
import com.alibaba.druid.util.StringUtils;
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.common.wrapper.QueryWrapperUtil;
import com.chinaztt.mes.plan.dto.ProcessConfigDTO;
import com.chinaztt.mes.plan.entity.CustomerOrder;
import com.chinaztt.mes.plan.entity.ProcessConfig;
import com.chinaztt.mes.plan.entity.ProcessConfigData;
import com.chinaztt.mes.plan.mapper.CustomerOrderMapper;
import com.chinaztt.mes.plan.mapper.ProcessConfigDataMapper;
import com.chinaztt.mes.plan.mapper.ProcessConfigMapper;
import com.chinaztt.mes.plan.service.ProcessConfigDataService;
import com.chinaztt.mes.plan.service.ProcessConfigService;
import com.chinaztt.mes.plan.state.auditstate.constant.AuditStateStringValues;
import lombok.AllArgsConstructor;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;


/**
 * 销售订单新工艺配置单
 *
 * @author yangyao
 * @date 2022-10-20 15:17:39
 */
@Service
@AllArgsConstructor
@Transactional(rollbackFor = Exception.class)
public class ProcessConfigServiceImpl extends ServiceImpl<ProcessConfigMapper, ProcessConfig> implements ProcessConfigService {

	private CustomerOrderMapper customerOrderMapper;

	private ProcessConfigDataMapper processConfigDataMapper;

	private ProcessConfigDataService processConfigDataService;

	private ProcessConfigMapper processConfigMapper;


	/**
	 * 批量新增新工艺配置单
	 *
	 * @param processConfigDTO
	 * @return
	 */
	@Override
	public boolean fullSave(ProcessConfigDTO processConfigDTO) {
		/* 排除已经配置过工艺配置单的订单行 start */
		List<ProcessConfig> processConfigBySearch = processConfigMapper.selectList(Wrappers.<ProcessConfig>lambdaQuery()
				.eq(ProcessConfig::getOrderNumber, processConfigDTO.getOrderNumber()));
		List<Long> customerOrderIdList = processConfigBySearch.stream().map(ProcessConfig::getOrderId).collect(Collectors.toList());
		List<CustomerOrder> customerOrderList = customerOrderMapper.selectList(Wrappers.<CustomerOrder>lambdaQuery()
				.eq(CustomerOrder::getCustomerOrderNo, processConfigDTO.getOrderNumber())
				.notIn(CollectionUtil.isNotEmpty(customerOrderIdList),CustomerOrder::getId,customerOrderIdList));
		/* 排除已经配置过工艺配置单的订单行 end */
		if(CollectionUtil.isNotEmpty(customerOrderList)) {
			//批量新增新工艺配置单主表
			List<ProcessConfig> processConfigList = new ArrayList<>();
			customerOrderList.stream().forEach(customerOrder -> {
				ProcessConfig processConfig = new ProcessConfig();
				BeanUtils.copyProperties(processConfigDTO, processConfig);
				processConfig.setOrderId(customerOrder.getId());
				processConfigList.add(processConfig);
			});
			saveBatch(processConfigList);
			//批量新增新工艺配置单副表
			List<ProcessConfigData> processConfigDataList = processConfigDTO.getProcessConfigDataList();
			if (CollectionUtil.isNotEmpty(processConfigDataList)) {
				processConfigList.stream().forEach(processConfig -> {
					saveProcessConfigData(processConfigDataList, processConfig.getId());
				});
			}
		}

		return true;
	}

	/**
	 * 新工艺配置单单条新增
	 *
	 * @param processConfigDTO
	 * @return
	 */
	@Override
	public boolean saveOneProcessConfig(ProcessConfigDTO processConfigDTO) {
		//新增新工艺配置单主表
		save(processConfigDTO);
		List<ProcessConfigData> processConfigDataList = processConfigDTO.getProcessConfigDataList();
		if (CollectionUtil.isNotEmpty(processConfigDataList)) {
			//新增新工艺配置单副表
			saveProcessConfigData(processConfigDataList, processConfigDTO.getId());
		}
		return true;
	}

	/**
	 * 根据订单id查询新工艺配置单信息
	 *
	 * @param orderId
	 * @return
	 */
	@Override
	public ProcessConfigDTO getProcessConfig(Long orderId) {
		ProcessConfigDTO processConfigDTO = baseMapper.selectByOrderId(orderId);
		return getProcessConfigDTO(processConfigDTO);
	}

	/**
	 * 根据订单号和otc行号查询新工艺配置单信息
	 *
	 * @param orderNo
	 * @param otcLineNo
	 * @return
	 */
	@Override
	public ProcessConfigDTO getByOrderNoAndOtcNo(String orderNo, String otcLineNo) {
		ProcessConfigDTO processConfigDTO = baseMapper.selectByOrderNoAndOtcNo(orderNo,otcLineNo);
		return getProcessConfigDTO(processConfigDTO);
	}


	/**
	 * 新工艺配置单单条编辑
	 *
	 * @param processConfigDTO
	 * @return R
	 */
	@Override
	public boolean updateById(ProcessConfigDTO processConfigDTO) {
		//订单行审核状态处于审批中或通过，配置单不可编辑
		judgeIsAudit(processConfigDTO.getOrderId());
		baseMapper.updateById(processConfigDTO);
		//删除新工艺配置副表信息
		deleteProcessConfigData(processConfigDTO.getId());
		List<ProcessConfigData> processConfigDataList = processConfigDTO.getProcessConfigDataList();
		if(CollectionUtil.isNotEmpty(processConfigDataList)){
			//新增新工艺配置副表信息
			saveProcessConfigData(processConfigDataList,processConfigDTO.getId());
		}
		return true;
	}

	/**
	 * 新工艺配置单应用至所选订单行
	 *
	 * @param processConfigDTO
	 * @return R
	 */
	@Override
	public boolean updateBatch(ProcessConfigDTO processConfigDTO) {
		List<CustomerOrder> customerOrderList = customerOrderMapper.selectList(Wrappers.<CustomerOrder>lambdaQuery()
				.in(CustomerOrder::getId, processConfigDTO.getOrderIdList()));
		for (CustomerOrder customerOrder:customerOrderList) {
			//订单行审核状态处于审批中或通过，配置单不可编辑
			judgeIsAudit(customerOrder.getId());
		}
		List<ProcessConfig> processConfigList = baseMapper.selectList(Wrappers.<ProcessConfig>lambdaQuery()
				.in(ProcessConfig::getOrderId,processConfigDTO.getOrderIdList()));
		if(CollectionUtil.isNotEmpty(processConfigList)) {
			for (ProcessConfig processConfig : processConfigList) {
				//根据订单号删除新工艺配置单副表信息
				deleteProcessConfigData(processConfig.getId());
			}
			//根据新工艺配置单主表id批量删除主表信息
			List<Long> processConfigIds = processConfigList.stream().map(ProcessConfig::getId).collect(Collectors.toList());
			baseMapper.deleteBatchIds(processConfigIds);
		}
		//新增新工艺配置单主表信息
		List<ProcessConfig> newProcessConfigList = new ArrayList<>();
		customerOrderList.stream().forEach(customerOrder -> {
			ProcessConfig processConfig = new ProcessConfig();
			BeanUtils.copyProperties(processConfigDTO, processConfig);
			processConfig.setOrderId(customerOrder.getId());
			newProcessConfigList.add(processConfig);
		});
		saveBatch(newProcessConfigList);
		//新增新工艺配置单副表信息
		List<ProcessConfigData> processConfigDataList = processConfigDTO.getProcessConfigDataList();
		if (CollectionUtil.isNotEmpty(processConfigDataList)) {
			newProcessConfigList.stream().forEach(newProcessConfig -> {
				saveProcessConfigData(processConfigDataList, newProcessConfig.getId());
			});
		}
		return true;
	}

	/**
	 * 删除新工艺配置单
	 *
	 * @param id
	 */
	@Override
	public boolean deleteById(Long id) {
		ProcessConfig processConfig = baseMapper.selectById(id);
		//订单行审核状态处于审批中或通过，配置单不可编辑
		judgeIsAudit(processConfig.getOrderId());
		//删除新工艺配置单主表信息
		baseMapper.deleteById(id);
		//删除新工艺配置单副表信息
		deleteProcessConfigData(id);
		return true;
	}

	/**
	 * 根据新工艺配置单主表id删除副表信息
	 *
	 * @param configId
	 */
	public void deleteProcessConfigData(Long configId){
		List<ProcessConfigData> processConfigDataList = processConfigDataMapper.selectList(Wrappers.<ProcessConfigData>lambdaQuery()
				.eq(ProcessConfigData::getConfigId, configId));
		if(CollectionUtil.isNotEmpty(processConfigDataList)){
			List<Long> dataIdList = processConfigDataList.stream().map(ProcessConfigData::getId).collect(Collectors.toList());
			processConfigDataMapper.deleteBatchIds(dataIdList);
		}
	}

	/**
	 * 批量新增新工艺配置单副表信息
	 *
	 * @param processConfigDataList
	 * @param configId
	 */
	public void saveProcessConfigData(List<ProcessConfigData> processConfigDataList,Long configId){
		processConfigDataList.stream().forEach(
				processConfigData -> {
					processConfigData.setConfigId(configId);
				});
		processConfigDataService.saveBatch(processConfigDataList);
	}

	/**
	 * 订单行审核状态处于审批中或通过，配置单不可编辑
	 *
	 * @param orderId
	 * @return
	 */
	public void judgeIsAudit(Long orderId){
		CustomerOrder customerOrder = customerOrderMapper.selectById(orderId);
		if(StringUtils.equals(customerOrder.getIsAudit(),AuditStateStringValues.PENDING)||
				StringUtils.equals(customerOrder.getIsAudit(),AuditStateStringValues.ACCEPTED)){
			throw new RuntimeException("订单行审核状态处于审批中或通过，配置单不可编辑");
		}
	}

	/**
	 * 根据新工艺配置单主表信息带出副表信息
	 *
	 * @param processConfigDTO
	 * @return
	 */
	public ProcessConfigDTO getProcessConfigDTO(ProcessConfigDTO processConfigDTO){
		if(processConfigDTO!=null) {
			List<ProcessConfigData> processConfigDataList = processConfigDataMapper.selectList(Wrappers.<ProcessConfigData>lambdaQuery()
					.eq(ProcessConfigData::getConfigId, processConfigDTO.getId()));
			processConfigDTO.setProcessConfigDataList(processConfigDataList);
			return processConfigDTO;

		}
		return null;
	}

	/**
	 * 工艺配置单分页查询
	 *
	 * @param page
	 * @param processConfigDTO
	 */
	@Override
	public IPage getProcessConfigPage(Page page, QueryWrapper<ProcessConfigDTO> processConfigDTO) {
		IPage iPage = baseMapper.getProcessConfigPage(page,processConfigDTO);
		return iPage;
	}
}