package com.chinaztt.mes.warehouse.util;

import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.util.BooleanUtil;
import cn.hutool.core.util.StrUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.chinaztt.ifs.api.feign.IfsFeignClient;
import com.chinaztt.mes.basic.entity.Part;
import com.chinaztt.mes.basic.mapper.PartMapper;
import com.chinaztt.mes.warehouse.dto.IfsMoveLibraryDTO;
import com.chinaztt.mes.warehouse.dto.MoveLibraryBoxDTO;
import com.chinaztt.mes.warehouse.entity.FeederCertificate;
import com.chinaztt.mes.warehouse.entity.Packaging;
import com.chinaztt.mes.warehouse.entity.Stock;
import com.chinaztt.mes.warehouse.entity.StockConfigBean;
import com.chinaztt.mes.warehouse.mapper.FeederCertificateMapper;
import com.chinaztt.mes.warehouse.mapper.PackagingItemMapper;
import com.chinaztt.mes.warehouse.mapper.PackagingMapper;
import com.chinaztt.mes.warehouse.mapper.StockMapper;
import com.chinaztt.mes.warehouse.state.constant.LocationTypeStringValues;
import com.chinaztt.mes.warehouse.state.escort.constant.EscortEvents;
import com.chinaztt.ztt.admin.api.feign.RemoteParamService;
import com.chinaztt.ztt.common.core.constant.SecurityConstants;
import com.chinaztt.ztt.common.core.util.R;
import com.google.gson.Gson;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.math.BigDecimal;
import java.util.*;
import java.util.stream.Collectors;

/**
 * @Description : 仓库管理工具类
 * @ClassName : WareHouseUtils
 * @Author : sll
 * @Date: 2022-06-02  22:04
 */
@Service
public class WareHouseUtils {
	@Resource
	private PackagingMapper packagingMapper;
	@Resource
	private PackagingItemMapper packagingItemMapper;
	@Resource
	private StockUtils stockUtils;
	@Resource
	private StockConfigBean stockConfigBean;
	@Resource
	private IfsFeignClient ifsFeignClient;
	@Resource
	private RemoteParamService remoteParamService;
	public static final String CONTRACT = "IFS_DOMAIN";
	@Resource
	private PartMapper partMapper;
	@Resource
	private StockMapper stockMapper;
	@Resource
	private FeederCertificateMapper feederMapper;

	/**
	 * 根据包装主表记录行id获取包装确认状态
	 *
	 * @param id
	 * @return
	 */
	public Boolean isPackConfirm(Long id) {
		Packaging packaging = packagingMapper.selectById(id);
		if (packaging == null) {
			throw new RuntimeException("包装主表id=" + id + "->异常->数据库无匹配记录");
		} else {
			return packaging.getIsConfirm();
		}

	}

	/**
	 * 校验mes库位映射ifs库位的对称性
	 *
	 * @param moveLibraryBoxDTOList
	 * @return false：不对称；true：对称
	 */
	public Boolean isLocationMapSym(List<MoveLibraryBoxDTO> moveLibraryBoxDTOList) {
		for (MoveLibraryBoxDTO moveLibraryBoxDTO : moveLibraryBoxDTOList) {
			if (StringUtils.isBlank(moveLibraryBoxDTO.getStartLocationNoIfs()) ^ StringUtils.isBlank(moveLibraryBoxDTO.getArriveLocationNoIfs())) {
				return false;
			}
		}
		return true;
	}

	/**
	 * 校验MoveLibraryBoxDTO
	 *
	 * @param moveLibraryBoxDTOList
	 * @param id
	 * @return
	 */
	public R checkMoveLibraryBox(List<MoveLibraryBoxDTO> moveLibraryBoxDTOList, Long id) {
		Long itemCount = packagingItemMapper.getPackagingItemCountByPackagingId(id);
		//校验SQL查询结果
		if (moveLibraryBoxDTOList.size() != itemCount) {
			return R.failed("实际明细行数=" + moveLibraryBoxDTOList.size() + "->不等于SQL关联查询明细行数=" + itemCount);
		}
		//校验box明细行是否都存在到达库位号且到达库位为成品库位
		List<MoveLibraryBoxDTO> moveLibraryBoxDTOListFilter = moveLibraryBoxDTOList.stream().filter(o -> StringUtils.isBlank(o.getArriveLocationNo()) || !o.getArriveLocationType().equals(LocationTypeStringValues.FINISHLOCATIONCODE)).collect(Collectors.toList());
		if (CollectionUtil.isNotEmpty(moveLibraryBoxDTOListFilter)) {
			return R.failed("包装明细存在记录行未指定[到达库位]");
		}
		//校验box明细行是否都存在出发库位号且出发库位是否是合格品库位
		moveLibraryBoxDTOListFilter = moveLibraryBoxDTOList.stream().filter(o -> StringUtils.isBlank(o.getStartLocationNo()) || !o.getStartLocationType().equals(LocationTypeStringValues.PRODOUTQUALIFIELDLOCATIONCODE)).collect(Collectors.toList());
		if (CollectionUtil.isNotEmpty(moveLibraryBoxDTOListFilter)) {
			return R.failed("包装明细存在记录行在实时库位中未找到[出发库位]或[出发库位]为非[产出合格品库位]");
		}


		//校验库位的对称性
		if (!isLocationMapSym(moveLibraryBoxDTOList)) {
			return R.failed("mes库位映射ifs库位不对称");
		}

		return R.ok();
	}

	/**
	 * 包装模块确认/取消确认后的移库
	 *
	 * @param moveLibraryBoxDTOList
	 * @param escortEvents          COMPLETE：确认；CANCEL：取消确认
	 * @param packagingId           包装主表id
	 */
	public void packagingMoveLibrary(List<MoveLibraryBoxDTO> moveLibraryBoxDTOList, EscortEvents escortEvents, Long packagingId) {
		//1.mes移库
		for (MoveLibraryBoxDTO moveLibraryBoxDTO : moveLibraryBoxDTOList) {
			switch (escortEvents) {
				case COMPLETE:
					stockUtils.localMove(moveLibraryBoxDTO.getPartId(), moveLibraryBoxDTO.getSystemNo(), moveLibraryBoxDTO.getBatchNo(), moveLibraryBoxDTO.getMoveQty(), moveLibraryBoxDTO.getStartLocationId(), moveLibraryBoxDTO.getArriveLocationId());
					break;
				case CANCEL:
					stockUtils.localMove(moveLibraryBoxDTO.getPartId(), moveLibraryBoxDTO.getSystemNo(), moveLibraryBoxDTO.getBatchNo(), moveLibraryBoxDTO.getMoveQty(), moveLibraryBoxDTO.getArriveLocationId(), moveLibraryBoxDTO.getStartLocationId());
					break;
				default:
					throw new RuntimeException("操作码" + escortEvents.name() + "->异常");
			}
		}

		//2.ifs移库
		List<MoveLibraryBoxDTO> moveLibraryBoxDTOListFilter = moveLibraryBoxDTOList.stream().filter(o -> StringUtils.isNotBlank(o.getStartLocationNoIfs()) && StringUtils.isNotBlank(o.getArriveLocationNoIfs())).collect(Collectors.toList());
		//将list按照零件号进行分组，去除IFS启用批次管理为true的数据
		Map<Long, List<MoveLibraryBoxDTO>> map = moveLibraryBoxDTOListFilter.stream().filter(x -> !x.getLotTrackingIfs()).collect(Collectors.groupingBy(MoveLibraryBoxDTO::getPartId));
		List<MoveLibraryBoxDTO> ifsList = new ArrayList<>();
		for (Map.Entry<Long, List<MoveLibraryBoxDTO>> entry : map.entrySet()) {
			List<MoveLibraryBoxDTO> moveLibraryBoxDTOByGroupList = entry.getValue();
			//汇总相同零件号的移库数量
			BigDecimal moveQtySum = moveLibraryBoxDTOByGroupList.stream().filter(x -> x.getMoveQty() != null).map(MoveLibraryBoxDTO::getMoveQty).reduce(BigDecimal.ZERO, BigDecimal::add);
			MoveLibraryBoxDTO ifsDTO = new MoveLibraryBoxDTO();
			BeanUtils.copyProperties(moveLibraryBoxDTOByGroupList.get(0), ifsDTO);
			ifsDTO.setMoveQty(moveQtySum);
			ifsList.add(ifsDTO);
		}

		//筛选出IFS启用批次管理为true的数据
		List<MoveLibraryBoxDTO> lotTrackingIfsList = moveLibraryBoxDTOListFilter.stream().filter(MoveLibraryBoxDTO::getLotTrackingIfs).collect(Collectors.toList());
		ifsList.addAll(lotTrackingIfsList);

		if (CollectionUtil.isNotEmpty(ifsList)) {
			//拼接inAttr
			IfsMoveLibraryDTO ifsMoveLibraryDTO = new IfsMoveLibraryDTO();
			//ifsMoveLibraryDTO.setRECORD_ID(packagingMapper.getPackingById(packagingId).getNo());
			List<IfsMoveLibraryDTO.DataBean> dataBeanList = new ArrayList<>();//批量标识
			for (MoveLibraryBoxDTO moveLibraryBoxDTO : ifsList) {
				// 工序库存不进行IFS移库
				Stock stock = stockMapper.selectById(moveLibraryBoxDTO.getStockId());
				if (BooleanUtil.isTrue(stock.getOperationStockStatus())) {
					continue;
				}
				IfsMoveLibraryDTO.DataBean batchInfo = new IfsMoveLibraryDTO.DataBean();
				batchInfo.setPART_NO(moveLibraryBoxDTO.getPartNo());//零件号
				batchInfo.setLOT_BATCH_NO(moveLibraryBoxDTO.getIfsBatchNo());//ifs批次号
				batchInfo.setMOVE_QTY(moveLibraryBoxDTO.getMoveQty());//移库数量
				//batchInfo.setSERIAL_NO("*");//序列号
				batchInfo.setENG_CHG_LEVEL(moveLibraryBoxDTO.getEngChgLevel());//版本号
				//判断是否启用批次管理
				if (moveLibraryBoxDTO.getLotTrackingIfs() != null && moveLibraryBoxDTO.getLotTrackingIfs()) {
					batchInfo.setWAIV_DEV_REJ_NO(moveLibraryBoxDTO.getBatchNo());//wdr号(存mes的sn号)
				} else {
					batchInfo.setWAIV_DEV_REJ_NO("*");//wdr号
					batchInfo.setLOT_BATCH_NO("*");
				}

				switch (escortEvents) {
					case COMPLETE:
						batchInfo.setLOCATION_NO(moveLibraryBoxDTO.getStartLocationNoIfs());//ifs出发库位号
						batchInfo.setTO_LOCATION_NO(moveLibraryBoxDTO.getArriveLocationNoIfs());//ifs到达库位号
						break;
					case CANCEL:
						batchInfo.setLOCATION_NO(moveLibraryBoxDTO.getArriveLocationNoIfs());//ifs出发库位号
						batchInfo.setTO_LOCATION_NO(moveLibraryBoxDTO.getStartLocationNoIfs());//ifs到达库位号
						break;
				}
				String contract = remoteParamService.getByKey(CONTRACT, SecurityConstants.FROM_IN).getData();//从系统参数中获取ifs域
				//batchInfo.setTO_CONTRACT(stockConfigBean.getRegion());//目标域
				// 因为现在多个 mes库位可能对应一个 ifs库位 所以 执行移库操作之前需要判断一下库位是否相同
				// xcg 20230413
				if (StrUtil.equals(batchInfo.getLOCATION_NO(), batchInfo.getTO_LOCATION_NO())) {
					continue;
				}
				batchInfo.setTO_CONTRACT(contract);//目标域
				dataBeanList.add(batchInfo);
			}
			if (CollectionUtils.isEmpty(dataBeanList)){
				return;
			}
			ifsMoveLibraryDTO.setBATCH_INFO(dataBeanList);
			Gson gson = new Gson();
			String jsonstr = gson.toJson(ifsMoveLibraryDTO);
			JSONObject jsonObject = JSONObject.parseObject(jsonstr);//解决序列化时自动将大写转小写问题

			R res = ifsFeignClient.importMovePartStd(jsonObject, true);
			if (res.getCode() != 0) {
				throw new RuntimeException("ifs库存件移库失败->ifs报错信息=" + res.getMsg());
			}
		}
	}

	/**
	 * 移库（通用）
	 *
	 * @param moveLibraryBoxDTOList
	 */
	public void moveLibrary(List<MoveLibraryBoxDTO> moveLibraryBoxDTOList) {
		List<MoveLibraryBoxDTO> moveLibraryBoxDTOList_tmp = moveLibraryBoxDTOList.stream().filter(o -> StringUtils.isBlank(o.getPlanningMethod())).collect(Collectors.toList());
		if (CollectionUtil.isNotEmpty(moveLibraryBoxDTOList_tmp)) {
			throw new RuntimeException("存在零件无[计划方法]->无法进行移库");
		}

		//1.mes移库
		for (MoveLibraryBoxDTO moveLibraryBoxDTO : moveLibraryBoxDTOList) {
			stockUtils.localMove(moveLibraryBoxDTO.getPartId(), moveLibraryBoxDTO.getSystemNo(), moveLibraryBoxDTO.getBatchNo(), moveLibraryBoxDTO.getMoveQty(), moveLibraryBoxDTO.getStartLocationId(), moveLibraryBoxDTO.getArriveLocationId());
		}

		//2.ifs移库
		List<MoveLibraryBoxDTO> moveLibraryBoxDTOListFilter = moveLibraryBoxDTOList.stream().filter(o -> StringUtils.isNotBlank(o.getStartLocationNoIfs()) && StringUtils.isNotBlank(o.getArriveLocationNoIfs()) && !o.getPlanningMethod().equals("K")).collect(Collectors.toList());
		if (CollectionUtil.isNotEmpty(moveLibraryBoxDTOListFilter)) {
			//拼接inAttr
			IfsMoveLibraryDTO ifsMoveLibraryDTO = new IfsMoveLibraryDTO();
			ifsMoveLibraryDTO.setRECORD_ID(UUID.randomUUID().toString());
			List<IfsMoveLibraryDTO.DataBean> dataBeanList = new ArrayList<>();//批量标识
			for (MoveLibraryBoxDTO moveLibraryBoxDTO : moveLibraryBoxDTOListFilter) {
				// 工序库存不进行移库
				Stock stock = stockMapper.selectById(moveLibraryBoxDTO.getStockId());
				if (BooleanUtil.isTrue(stock.getOperationStockStatus())) {
					continue;
				}
				IfsMoveLibraryDTO.DataBean batchInfo = new IfsMoveLibraryDTO.DataBean();
				batchInfo.setPART_NO(moveLibraryBoxDTO.getPartNo());//零件号
				batchInfo.setLOT_BATCH_NO(moveLibraryBoxDTO.getIfsBatchNo());//ifs批次号
				batchInfo.setMOVE_QTY(moveLibraryBoxDTO.getMoveQty());//移库数量
				//batchInfo.setSERIAL_NO("*");//序列号
				batchInfo.setENG_CHG_LEVEL(moveLibraryBoxDTO.getEngChgLevel());//版本号
				//batchInfo.setWAIV_DEV_REJ_NO("*");//wdr号
				Part part = partMapper.selectById(moveLibraryBoxDTO.getPartId());
				//判断是否启用批次管理
				if (part.getLotTrackingIfs() != null && part.getLotTrackingIfs()) {
					FeederCertificate feederCertificate =
							feederMapper.selectOne(Wrappers.<FeederCertificate>lambdaQuery().eq(FeederCertificate::getSn, moveLibraryBoxDTO.getBatchNo()));
					if (null != feederCertificate) {
						batchInfo.setWAIV_DEV_REJ_NO(org.apache.commons.lang3.StringUtils.isNotBlank(feederCertificate.getExaminerAfter()) ? feederCertificate.getExaminerAfter() : feederCertificate.getExaminer());
					} else {
						batchInfo.setWAIV_DEV_REJ_NO(moveLibraryBoxDTO.getBatchNo());//wdr号(把mes的sn号放里面)
					}
				} else {
					batchInfo.setWAIV_DEV_REJ_NO("*");//wdr号
				}
				batchInfo.setLOCATION_NO(moveLibraryBoxDTO.getStartLocationNoIfs());//ifs出发库位号
				batchInfo.setTO_LOCATION_NO(moveLibraryBoxDTO.getArriveLocationNoIfs());//ifs到达库位号
				batchInfo.setTO_CONTRACT(stockConfigBean.getRegion());//目标域
				// 因为现在多个 mes库位可能对应一个 ifs库位 所以 执行移库操作之前需要判断一下库位是否相同
				// xcg 20230413
				if (StrUtil.equals(batchInfo.getLOCATION_NO(), batchInfo.getTO_LOCATION_NO())) {
					continue;
				}
				dataBeanList.add(batchInfo);
			}
			if (CollectionUtil.isEmpty(dataBeanList)) {
				return;
			}
			ifsMoveLibraryDTO.setBATCH_INFO(dataBeanList);
			Gson gson = new Gson();
			String jsonstr = gson.toJson(ifsMoveLibraryDTO);
			JSONObject jsonObject = JSONObject.parseObject(jsonstr);//解决序列化时自动将大写转小写问题

			R res = ifsFeignClient.importMovePartStd(jsonObject, true);
			if (res.getCode() != 0) {
				throw new RuntimeException("{" + moveLibraryBoxDTOListFilter.get(0).getBatchNo() + "}IFS与MES库存不一致");
			}
		}
	}

	/**
	 * 精准查询ifs库存（零件号、批次号、wdr号）
	 *
	 * @param partNo  零件号
	 * @param batchNo 批次号
	 * @param wdr     wdr号
	 * @return
	 */
	public R getIfsStockPrecise(String partNo, String batchNo, String wdr) {
		if (StringUtils.isBlank(partNo) || StringUtils.isBlank(batchNo) || StringUtils.isBlank(wdr)) {
			throw new RuntimeException("零件号&&批次号&&wdr号传参不可为空");
		}

		JSONObject jsonObject = new JSONObject();
		jsonObject.put("PART_NO", partNo);
		jsonObject.put("QUANTITY_FLAG", ">0");
		jsonObject.put("LOT_BATCH_NO", batchNo);
		jsonObject.put("WDR_NO", wdr);
		R result = ifsFeignClient.queryInventoryInfoStd(jsonObject, true);
		if (result.getCode() == 0) {
			JSONObject data = (JSONObject) JSON.toJSON(result.getData());
			JSONArray array = new JSONArray();
			for (int i = 0; i < data.getJSONArray("LIST_INFO").size(); i++) {
				if (data.getJSONArray("LIST_INFO").getJSONObject(i).getBigDecimal("QTY_AVAILABLE").compareTo(BigDecimal.ZERO) > 0) {
					array.add(data.getJSONArray("LIST_INFO").getJSONObject(i));
				}
			}
			return R.ok(array, "OK");
		} else {
			throw new RuntimeException(result.getMsg());
		}
	}
}