/*
 *    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.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.chinaztt.ifs.api.feign.IfsFeignClient;
import com.chinaztt.mes.basic.util.BigDecimalUtils;
import com.chinaztt.mes.common.wrapper.QueryWrapperUtil;
import com.chinaztt.mes.plan.dto.ManufacturingOrderMatIssueDTO;
import com.chinaztt.mes.plan.dto.MoStructureComponentDTO;
import com.chinaztt.mes.plan.entity.ManufacturingOrder;
import com.chinaztt.mes.plan.entity.ManufacturingOrderMatIssue;
import com.chinaztt.mes.plan.entity.MoStructureComponent;
import com.chinaztt.mes.plan.mapper.ManufacturingOrderMapper;
import com.chinaztt.mes.plan.mapper.ManufacturingOrderMatIssueMapper;
import com.chinaztt.mes.plan.mapper.MoStructureComponentMapper;
import com.chinaztt.mes.plan.service.ManufacturingOrderMatIssueService;
import com.chinaztt.mes.plan.state.manufacturing.constant.ManufacturingOrderStates;
import com.chinaztt.mes.warehouse.entity.Stock;
import com.chinaztt.mes.warehouse.mapper.StockMapper;
import com.chinaztt.mes.warehouse.util.StockUtils;
import com.chinaztt.ztt.common.core.util.R;
import lombok.AllArgsConstructor;
import org.springframework.stereotype.Service;

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

/**
 * 客户订单主表
 *
 * @author sunxl
 * @date 2021-08-16 10:55:28
 */
@Service
@AllArgsConstructor
public class ManufacturingOrderMatIssueServiceImpl extends ServiceImpl<ManufacturingOrderMatIssueMapper, ManufacturingOrderMatIssue> implements ManufacturingOrderMatIssueService {

	private IfsFeignClient ifsFeignClient;
	private ManufacturingOrderMapper manufacturingOrderMapper;
	private MoStructureComponentMapper moStructureComponentMapper;
	private StockMapper stockMapper;
	private StockUtils stockUtils;

	/**
	 * 根据零件号从库存查询发料数量
	 *
	 * @param moId
	 * @return
	 */
	@Override
	public R getMatIssueFromStock(Long moId, String wdrNo, String lotBatchNo) {
		try {
			MoStructureComponent moStructureComponent = moStructureComponentMapper.selectOne(Wrappers.<MoStructureComponent>lambdaQuery()
					.eq(MoStructureComponent::getPlanManufacturingOrderId, moId)
					.isNull(MoStructureComponent::getParent));
			List<ManufacturingOrderMatIssueDTO> manufacturingOrderMatIssueDTOS = new ArrayList<>();
			if (moStructureComponent != null) {
				getMatIssue(moStructureComponent.getId(), wdrNo, lotBatchNo, manufacturingOrderMatIssueDTOS);
			}
			return R.ok(manufacturingOrderMatIssueDTOS);
		} catch (Exception e) {
			return R.failed("获取异常");
		}
	}

	private void getMatIssue(Long parentId, String wdrNo, String lotBatchNo, List<ManufacturingOrderMatIssueDTO> manufacturingOrderMatIssueDTOS) {
		List<ManufacturingOrderMatIssueDTO> manufacturingOrderMatIssueList = baseMapper.getMatIssueFromStock(parentId);
		Map<Long, List<ManufacturingOrderMatIssueDTO>> manufacturingOrderMatIssueMap =
				manufacturingOrderMatIssueList.stream().collect(Collectors.groupingBy(ManufacturingOrderMatIssueDTO::getStrucId));
		for (Map.Entry<Long, List<ManufacturingOrderMatIssueDTO>> entry :
				manufacturingOrderMatIssueMap.entrySet()) {
			List<ManufacturingOrderMatIssueDTO> list = entry.getValue();
			for (ManufacturingOrderMatIssueDTO manufacturingOrderMatIssueDTO : list) {
				if (checkMatIssue(wdrNo, lotBatchNo, manufacturingOrderMatIssueDTO)) {
					manufacturingOrderMatIssueDTOS.add(manufacturingOrderMatIssueDTO);
				}
			}
			getMatIssue(entry.getKey(), wdrNo, lotBatchNo, manufacturingOrderMatIssueDTOS);
		}

	}

	/**
	 * 根据wdrNo 和 SN号 判断筛选条件
	 *
	 * @param wdrNo
	 * @param lotBatchNo
	 * @param manufacturingOrderMatIssueDTO
	 * @return
	 */
	private boolean checkMatIssue(String wdrNo, String lotBatchNo, ManufacturingOrderMatIssueDTO manufacturingOrderMatIssueDTO) {
		if (StringUtils.isNotBlank(wdrNo)) {
			if (!manufacturingOrderMatIssueDTO.getWdrNo().equals(wdrNo)) {
				return false;
			}
		}
		if (StringUtils.isNotBlank(lotBatchNo)) {
			if (!manufacturingOrderMatIssueDTO.getLotBatchNo().equals(lotBatchNo)) {
				return false;
			}
		}
		return true;
	}

	/**
	 * 根据零件号从库存查询发料数量
	 *
	 * @param moId
	 * @return
	 */
	@Override
	public R getMatIssueFromIfs(Long moId) {
		try {
			List<MoStructureComponentDTO> moStructureComponentDTOList = baseMapper.getMatIssuePartNoFromIfs(moId);
			List<ManufacturingOrderMatIssue> manufacturingOrderMatIssueList = new ArrayList<>();
			String partNos = "";
			Map<String, String> map = new HashMap<>();
			for (MoStructureComponentDTO moStructureComponentDTO : moStructureComponentDTOList) {
				partNos += moStructureComponentDTO.getPartNo() + ";";
				map.put(moStructureComponentDTO.getPartNo(), moStructureComponentDTO.getIfsLineItemNo());
			}
			if (StringUtils.isBlank(partNos)) {
				return R.ok(manufacturingOrderMatIssueList);
			}
			JSONObject jsonObject = new JSONObject().fluentPut("PART_NO", partNos);
			R result = ifsFeignClient.queryInventoryInfoStd(jsonObject, true);
			if (result.getCode() == 0) {
				JSONObject data = (JSONObject) JSON.toJSON(result.getData());
				JSONArray jsonArray = data.getJSONArray("LIST_INFO");
				for (int i = 0; i < jsonArray.size(); i++) {
					JSONObject info = jsonArray.getJSONObject(i);
					if (BigDecimalUtils.getBigDecimalValue(info.getBigDecimal("QTY_AVAILABLE")).compareTo(BigDecimal.ZERO) <= 0) {
						continue;
					}
					ManufacturingOrderMatIssue manufacturingOrderMatIssue = new ManufacturingOrderMatIssue();
					String partNo = info.getString("PART_NO");
					//零件编号
					manufacturingOrderMatIssue.setPartNo(partNo);
					//行项号
					manufacturingOrderMatIssue.setIfsLineItemNo(map.get(partNo));
					//零件描述
					manufacturingOrderMatIssue.setPartName(info.getString("PART_DESC"));
					//单位
					manufacturingOrderMatIssue.setUnit(info.getString("UNIT_MEAS"));
					//版本号
					manufacturingOrderMatIssue.setEngChgLevel(info.getString("ENG_CHG_LEVEL"));
					//库位编号
					manufacturingOrderMatIssue.setLocationNo(info.getString("LOCATION_NO"));
					//库位描述
					manufacturingOrderMatIssue.setLocationName(info.getString("LOCATION_DESC"));
					//批次号
					manufacturingOrderMatIssue.setLotBatchNo(info.getString("LOT_BATCH_NO"));
					//WDR 号码
					manufacturingOrderMatIssue.setWdrNo(info.getString("WAIV_DEV_REJ_NO"));
					//库位id
					manufacturingOrderMatIssue.setWarehouse(info.getString("WAREHOUSE_ID"));
					//序列号
					manufacturingOrderMatIssue.setSerialNo(info.getString("SERIAL_NO"));
					//可用数量
					manufacturingOrderMatIssue.setQtyIssue(info.getBigDecimal("QTY_AVAILABLE"));
					//可用数量
					manufacturingOrderMatIssue.setQtyRequired(info.getBigDecimal("QTY_AVAILABLE"));

					manufacturingOrderMatIssue.setMatFrom("IFS");
					manufacturingOrderMatIssueList.add(manufacturingOrderMatIssue);
				}
				return R.ok(manufacturingOrderMatIssueList);
			} else {
				return R.failed("IFS错误——" + result.getMsg());
			}
		} catch (Exception e) {
			return R.failed("获取异常");
		}
	}

	@Override
	public List<ManufacturingOrderMatIssue> getMatIssueList(Long moId) {
		return baseMapper.selectList(Wrappers.<ManufacturingOrderMatIssue>lambdaQuery().eq(ManufacturingOrderMatIssue::getMoId, moId));
	}

	/**
	 * 车间订单发料
	 *
	 * @param manufacturingOrderMatIssues
	 * @param moId                        车间订单编号
	 * @return
	 */
	@Override
	public R addMatIssue(List<ManufacturingOrderMatIssue> manufacturingOrderMatIssues, Long moId) {
		try {
			ManufacturingOrder manufacturingOrder = manufacturingOrderMapper.selectById(moId);
			if (!manufacturingOrder.getState().equals(ManufacturingOrderStates.ISSUED.getValue())) {
				return R.failed("非已下达订单不可进行发料");
			}
			JSONObject param = new JSONObject().fluentPut("RECORD_ID", UUID.randomUUID().toString()).fluentPut("SYSCODE", "LMES").fluentPut("SYSMODEL", "车间订单发料");
			JSONArray infoArray = new JSONArray();
			for (ManufacturingOrderMatIssue manufacturingOrderMatIssue : manufacturingOrderMatIssues) {
				JSONObject info = new JSONObject();
				//如果是从库存来的得先删除库存
				if (manufacturingOrderMatIssue.getStockId() != null) {
					Stock stock = stockMapper.selectById(manufacturingOrderMatIssue.getStockId());
					if (stock == null) {
						throw new RuntimeException("库存丢失");
					}
					if (stock.getAvailableStockQuantity().compareTo(manufacturingOrderMatIssue.getQtyIssue()) == -1) {
						throw new RuntimeException("库存不够");
					}
				}
				info.put("ORDER_NO", manufacturingOrder.getIfsOrderNo());               //订单号
				info.put("RELEASE_NO", manufacturingOrder.getIfsReleaseNo());           //下达号
				info.put("SEQUENCE_NO", manufacturingOrder.getIfsSequenceNo());         //序列号
				if (StringUtils.isNotBlank(manufacturingOrderMatIssue.getIfsLineItemNo())) {
					info.put("LINE_ITEM_NO", new Long(manufacturingOrderMatIssue.getIfsLineItemNo()));//行项号
				}
				info.put("PART_NO", manufacturingOrderMatIssue.getPartNo());            //零件编号
				info.put("LOCATION_NO", manufacturingOrderMatIssue.getLocationNo());    //库位号
				info.put("LOT_BATCH_NO", manufacturingOrderMatIssue.getLotBatchNo());   //批次号
				info.put("SERIAL_NO", manufacturingOrderMatIssue.getSerialNo());        //序列号 默认是
				info.put("ENG_CHG_LEVEL", manufacturingOrderMatIssue.getEngChgLevel()); //版本号
				info.put("WAIV_DEV_REJ_NO", manufacturingOrderMatIssue.getWdrNo());     //WDR编号
				info.put("QTY_TO_ISSUE", manufacturingOrderMatIssue.getQtyIssue());     //要下发数量
				infoArray.add(info);
			}
			param.put("BATCH_INFO", infoArray);
			param.put("mesParams", new JSONObject()
					.fluentPut("manufacturingOrderId", moId)
					.fluentPut("SYSMODEL", "车间订单发料")
					.fluentPut("manufacturingOrderMatIssuesList", manufacturingOrderMatIssues)
					.fluentPut("manufacturingOrderMatIssueArray", infoArray));
			R result = ifsFeignClient.importSoMaterialIssueStd(param, true);
			if (result.getCode() == 0) {
				for (ManufacturingOrderMatIssue manufacturingOrderMatIssue : manufacturingOrderMatIssues) {
					if (manufacturingOrderMatIssue.getStockId() != null) {
						stockUtils.updateById(manufacturingOrderMatIssue.getStockId(), manufacturingOrderMatIssue.getQtyIssue().negate(), BigDecimal.ZERO, BigDecimal.ZERO, BigDecimal.ZERO, manufacturingOrder.getMoNo(), "MOMATISSUE");
					}
					manufacturingOrderMatIssue.setMoId(moId);
					baseMapper.insert(manufacturingOrderMatIssue);
				}
				return R.ok().setMsg("成功");
			} else {
				return R.failed("IFS错误——" + result.getMsg());
			}
		} catch (Exception e) {
			return R.failed("同步异常");
		}
	}

	/**
	 * 车间订单取消发料
	 *
	 * @param ids 发料数据的ids
	 * @return
	 */
	@Override
	public R delMatUnIssue(List<Long> ids) {
		try {
			if (CollectionUtil.isEmpty(ids)) {
				throw new RuntimeException("参数不能为空");
			}
			List<ManufacturingOrderMatIssue> manufacturingOrderMatIssues =
					baseMapper.selectList(Wrappers.<ManufacturingOrderMatIssue>lambdaQuery().in(ManufacturingOrderMatIssue::getId, ids));
			if (CollectionUtil.isEmpty(manufacturingOrderMatIssues)) {
				throw new RuntimeException("无发料明细");
			}
			ManufacturingOrder manufacturingOrder =
					manufacturingOrderMapper.selectById(manufacturingOrderMatIssues.get(0).getMoId());
			if (!manufacturingOrder.getState().equals(ManufacturingOrderStates.ISSUED.getValue())) {
				return R.failed("非已下达订单不可进行取消发料");
			}
			// 获取发料明细对应库存是工序库存的数据
			List<Long> stockIdList =
					manufacturingOrderMatIssues.stream().map(ManufacturingOrderMatIssue::getStockId).collect(Collectors.toList());
			List<Object> operationStockIdList =
					stockMapper.selectObjs(Wrappers.<Stock>lambdaQuery().select(Stock::getId).in(Stock::getId,
							stockIdList).eq(Stock::getOperationStockStatus, Boolean.TRUE));
			JSONObject param = new JSONObject().fluentPut("RECORD_ID", UUID.randomUUID().toString()).fluentPut("SYSCODE", "LMES").fluentPut("SYSMODEL", "车间订单取消发料");
			JSONArray infoArray = new JSONArray();
			for (ManufacturingOrderMatIssue manufacturingOrderMatIssue : manufacturingOrderMatIssues) {
				// 如果是工序库存，则不对接IFS
				if (CollectionUtil.isNotEmpty(operationStockIdList) &&
						operationStockIdList.stream().anyMatch(i -> i.equals(manufacturingOrderMatIssue.getStockId()))) {
					continue;
				}
				JSONObject info = new JSONObject();
				info.put("ORDER_NO", manufacturingOrder.getIfsOrderNo());               //订单号
				info.put("RELEASE_NO", manufacturingOrder.getIfsReleaseNo());           //下达号
				info.put("SEQUENCE_NO", manufacturingOrder.getIfsSequenceNo());         //序列号
				if (StringUtils.isNotBlank(manufacturingOrderMatIssue.getIfsLineItemNo())) {
					info.put("LINE_ITEM_NO", new Long(manufacturingOrderMatIssue.getIfsLineItemNo()));//行项号
				}
				info.put("PART_NO", manufacturingOrderMatIssue.getPartNo());            //零件编号
				info.put("LOCATION_NO", manufacturingOrderMatIssue.getLocationNo());    //库位号
				info.put("LOT_BATCH_NO", manufacturingOrderMatIssue.getLotBatchNo());   //批次号
				info.put("SERIAL_NO", manufacturingOrderMatIssue.getSerialNo());        //序列号 默认是
				info.put("ENG_CHG_LEVEL", manufacturingOrderMatIssue.getEngChgLevel()); //版本号
				info.put("WAIV_DEV_REJ_NO", manufacturingOrderMatIssue.getWdrNo());     //WDR编号
				info.put("QTY_TO_UNISSUE", manufacturingOrderMatIssue.getQtyIssue());     //要下发数量
				infoArray.add(info);
			}
			param.put("BATCH_INFO", infoArray);
			param.put("mesParams", new JSONObject()
					.fluentPut("manufacturingOrderId", manufacturingOrderMatIssues.get(0).getMoId())
					.fluentPut("SYSMODEL", "车间订单取消发料")
					.fluentPut("manufacturingOrderMatIssueArray", infoArray));
			R result = ifsFeignClient.importSoMaterialUnissueStd(param, true);
			if (result.getCode() == 0) {
				manufacturingOrderMatIssues.forEach(manufacturingOrderMatIssue -> {
					if (manufacturingOrderMatIssue.getStockId() != null) {
						stockUtils.updateById(manufacturingOrderMatIssue.getStockId(), manufacturingOrderMatIssue.getQtyIssue(), BigDecimal.ZERO, BigDecimal.ZERO, BigDecimal.ZERO, manufacturingOrder.getMoNo(), "MOMATUNISSUE");
					}
				});
				baseMapper.delete(Wrappers.<ManufacturingOrderMatIssue>lambdaQuery().in(ManufacturingOrderMatIssue::getId, ids));
				return R.ok().setMsg("成功");
			} else {
				return R.failed("IFS错误——" + result.getMsg());
			}
		} catch (Exception e) {
			return R.failed("同步异常");
		}
	}

	/**
	 * 不分页查询
	 *
	 * @param manufacturingOrderMatIssue
	 * @return
	 */
	@Override
	public List<ManufacturingOrderMatIssue> list(ManufacturingOrderMatIssue manufacturingOrderMatIssue) {
		return baseMapper.selectList(QueryWrapperUtil.gen(manufacturingOrderMatIssue));
	}
}