package com.chinaztt.mes.production.util;

import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.util.BooleanUtil;
import cn.hutool.json.JSONUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.chinaztt.ifs.api.feign.IfsFeignClient;
import com.chinaztt.mes.basic.entity.IfsLog;
import com.chinaztt.mes.basic.mapper.IfsLogMapper;
import com.chinaztt.mes.plan.entity.ManufacturingOrder;
import com.chinaztt.mes.plan.entity.ManufacturingOrderMatIssue;
import com.chinaztt.mes.plan.mapper.ManufacturingOrderMatIssueMapper;
import com.chinaztt.mes.plan.service.ManufacturingOrderService;
import com.chinaztt.mes.production.entity.ProductMainIfsReport;
import com.chinaztt.mes.production.mapper.ProductMainIfsReportMapper;
import com.chinaztt.mes.quality.entity.QualityMainIfsReport;
import com.chinaztt.mes.quality.mapper.QualityMainIfsReportMapper;
import com.chinaztt.mes.warehouse.util.StockUtils;
import com.chinaztt.ztt.common.core.util.R;
import lombok.AllArgsConstructor;
import org.springframework.mock.web.MockHttpServletRequest;
import org.springframework.stereotype.Component;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;

import java.math.BigDecimal;
import java.util.List;
import java.util.UUID;

/**
 * @Description:
 * @Author: shz
 * @Date: 2022/7/29 15:34
 */
@AllArgsConstructor
@Component
public class IfsCommonUtils {
	private IfsFeignClient ifsFeignClient;
	private IfsLogMapper ifsLogMapper;
	private StockUtils stockUtils;
	private ProductMainIfsReportMapper productMainIfsReportMapper;
	private ManufacturingOrderService manufacturingOrderService;
	private ManufacturingOrderMatIssueMapper manufacturingOrderMatIssueMapper;
	private QualityMainIfsReportMapper qualityMainIfsReportMapper;

	public static final String IMPORT_SO_OPER_REPORT_STD = "IMPORT_SO_OPER_REPORT_STD";
	public static final String IMPORT_SO_OPER_UNREPORT_STD = "IMPORT_SO_OPER_UNREPORT_STD";
	/**
	 * 车间订单及物料工序新增、更新接口
	 */
	public static final String IMPORT_SO_SMA_SOPER_STD = "IMPORT_SO_SMA_SOPER_STD";
	/**
	 * 车间订单状态修改
	 */
	public static final String MODIFY_SO_STATE_STD = "MODIFY_SO_STATE_STD";
	/**
	 * 车间订单预处理
	 */
	public static final String MODIFY_SO_PRE_CLOSE_STD = "MODIFY_SO_PRE_CLOSE_STD";
	/**
	 * 车间订单发料 外协
	 */
	public static final String IMPORT_SO_MATERIAL_ISSUE_STD = "IMPORT_SO_MATERIAL_ISSUE_STD";
	/**
	 * 车间订单取消发料 外协
	 */
	public static final String IMPORT_SO_MATERIAL_UNISSUE_STD = "IMPORT_SO_MATERIAL_UNISSUE_STD";


	public R executeCaches() {
		RequestContextHolder.setRequestAttributes(new ServletRequestAttributes(new MockHttpServletRequest()));
		R r = ifsFeignClient.queryAllIfsCache();
		if (r.getCode() == 0) {
			List<Integer> logIdList = (List<Integer>) r.getData();
			if (!logIdList.isEmpty()) {
				for (int i = 0; i < logIdList.size(); i++) {
					Integer logId = logIdList.get(i);
					IfsLog ifsLog = ifsLogMapper.selectById(logId);
					if (BooleanUtil.isTrue(ifsLog.getInterruptFlag())) {
						break;
					}
					if(ifsLog.getActive()) {
						// 判断请求是否为需要更新参数
						updateParams(ifsLog);
						// 请求ifs
						R result = ifsFeignClient.updateIfsCacheStatus(ifsLog.getId());
						if (result.getCode() == 0) {
							JSONObject response = (JSONObject) JSON.toJSON(result.getData());
							// 判断结果是否需要缓存或处理
							updateResults(ifsLog, response);
						} else {
							updateNextInterruptFlag(logIdList.get(i + 1));
							return result;
						}

					}
				}
			}
		} else {
			return r;
		}
		return R.ok();
	}

	private void updateNextInterruptFlag(Integer id) {
		ifsLogMapper.update(null, new UpdateWrapper<IfsLog>().set("interrupt_flag", Boolean.TRUE).eq("id", id));
	}

	public R executeCachesById(Long logId) {
		IfsLog ifsLog = ifsLogMapper.selectById(logId);
		if(ifsLog!=null) {
			if(ifsLog.getActive()) {
				// 判断请求是否为需要更新参数，
				updateParams(ifsLog);
				// 请求ifs
				R result = ifsFeignClient.updateIfsCacheStatus(ifsLog.getId());
				if (result.getCode() == 0) {
					JSONObject response = (JSONObject) JSON.toJSON(result.getData());
					// 判断结果是否需要缓存或处理
					updateResults(ifsLog, response);
				} else {
					return result;
				}
			}
		}
		return R.ok();
	}





	private void updateResults(IfsLog ifsLog, JSONObject result) {
		switch (ifsLog.getProcedureName()) {
			// 工序报工
			case IMPORT_SO_OPER_REPORT_STD:
				if (ifsLog.getMesParams().contains("productMainId")) {
					updateReportResult(result, JSONObject.parseObject(ifsLog.getMesParams()));
				} else if (ifsLog.getMesParams().contains("qualityReportId")) {
					updateTestReportResult(result, JSONObject.parseObject(ifsLog.getMesParams()));
				}
				break;
			// 工序报工取消
			case IMPORT_SO_OPER_UNREPORT_STD:
				// 删除报工取消id
				if (ifsLog.getMesParams().contains("productMainId")) {
					Long productMainId = JSONObject.parseObject(ifsLog.getMesParams()).getLongValue("productMainId");
					productMainIfsReportMapper.delete(Wrappers.<ProductMainIfsReport>lambdaQuery().eq(ProductMainIfsReport::getProductMainId, productMainId));
				} else if (ifsLog.getMesParams().contains("qualityReportId")) {
					Long qualityReportId = JSONObject.parseObject(ifsLog.getMesParams()).getLongValue("qualityReportId");
					qualityMainIfsReportMapper.delete(Wrappers.<QualityMainIfsReport>lambdaQuery().eq(QualityMainIfsReport::getQualityReportId, qualityReportId));
				}
				break;
			//车间订单工序更新
			case IMPORT_SO_SMA_SOPER_STD:
				manufacturingOrderService.moIfsResult(result.getJSONArray("LIST_INFO"));
				break;
			//车间订单发料
			case IMPORT_SO_MATERIAL_ISSUE_STD:
				updateManufacturingOrderMatIssuesResult(ifsLog);
				break;
			//车间订单外协发料取消
			case IMPORT_SO_MATERIAL_UNISSUE_STD:
				updateManufacturingOrderMatIssuesResultCancel(ifsLog);
				break;
		}
	}

	private void updateParams(IfsLog ifsLog) {
		switch (ifsLog.getProcedureName()) {
			// 报工取消
			case IMPORT_SO_OPER_UNREPORT_STD:
				if (ifsLog.getMesParams().contains("productMainId")) {
					updateUnReportParams(ifsLog);
				} else if (ifsLog.getMesParams().contains("qualityReportId")) {
					updateUnTestReportParams(ifsLog);
				}
				break;
			// 车间订单状态修改
			case MODIFY_SO_STATE_STD:
				updateManufacturingOrderState(ifsLog);
				break;
			// 车间订单预处理
			case MODIFY_SO_PRE_CLOSE_STD:
				updateManufacturingOrderState(ifsLog);
				break;
			// 车间订单取消发料
			case IMPORT_SO_MATERIAL_UNISSUE_STD:
				updateManufacturingOrderMatIssues(ifsLog);
				break;
			// 车间订单发料
			case IMPORT_SO_MATERIAL_ISSUE_STD:
				updateManufacturingOrderMatIssues(ifsLog);
				break;
		}
	}

	/**
	 * 车间订单发料和取消发料
	 *
	 * @param ifsLog
	 */
	private void updateManufacturingOrderMatIssues(IfsLog ifsLog) {
		JSONObject mesParams = JSONObject.parseObject(ifsLog.getMesParams());
		Long manufacturingOrderId = mesParams.getLongValue("manufacturingOrderId");
		JSONArray manufacturingOrderIssueArray = mesParams.getJSONArray("manufacturingOrderMatIssueArray");
		String sysmodel = mesParams.getString("SYSMODEL");
		ManufacturingOrder manufacturingOrder = manufacturingOrderService.selectById(manufacturingOrderId);
		JSONObject params = new JSONObject().fluentPut("RECORD_ID", UUID.randomUUID().toString()).fluentPut("SYSCODE", "LMES").fluentPut("SYSMODEL", sysmodel);
		JSONArray infoArray = new JSONArray();
		for (Object object : manufacturingOrderIssueArray) {
			JSONObject jsonObjectIssue = JSONObject.parseObject(object.toString());
			jsonObjectIssue.put("ORDER_NO", manufacturingOrder.getIfsOrderNo());               //订单号
			jsonObjectIssue.put("RELEASE_NO", manufacturingOrder.getIfsReleaseNo());           //下达号
			jsonObjectIssue.put("SEQUENCE_NO", manufacturingOrder.getIfsSequenceNo());         //序列号
			infoArray.add(jsonObjectIssue);
		}
		params.put("BATCH_INFO", infoArray);
		// 更新缓存参数
		IfsLog update = new IfsLog();
		update.setId(ifsLog.getId());
		update.setInAttr(params.toJSONString());
		ifsLogMapper.updateById(update);
	}


	/**
	 * 外协发料后进行移库
	 *
	 * @param ifsLog
	 */
	private void updateManufacturingOrderMatIssuesResult(IfsLog ifsLog) {
		JSONObject mesParams = JSONObject.parseObject(ifsLog.getMesParams());
		JSONArray jsonArray = mesParams.getJSONArray("manufacturingOrderMatIssuesList");
		Long manufacturingOrderId = mesParams.getLongValue("manufacturingOrderId");
		ManufacturingOrder manufacturingOrder = manufacturingOrderService.selectById(manufacturingOrderId);
		for (Object object : jsonArray) {
			ManufacturingOrderMatIssue manufacturingOrderMatIssue = JSONUtil.toBean(object.toString(), ManufacturingOrderMatIssue.class);
			if (manufacturingOrderMatIssue.getStockId() != null) {
				//移库
				stockUtils.updateById(manufacturingOrderMatIssue.getStockId(),
						manufacturingOrderMatIssue.getQtyIssue().negate(), BigDecimal.ZERO, BigDecimal.ZERO, BigDecimal.ZERO,
						manufacturingOrder.getMoNo(), "MOMATISSUE");
			}
			manufacturingOrderMatIssue.setMoId(manufacturingOrderId);
			manufacturingOrderMatIssueMapper.insert(manufacturingOrderMatIssue);
		}
	}

	/**
	 * 外协取消发料后进行移库
	 *
	 * @param ifsLog
	 */
	private void updateManufacturingOrderMatIssuesResultCancel(IfsLog ifsLog) {
		JSONObject mesParams = JSONObject.parseObject(ifsLog.getMesParams());
		JSONArray jsonArray = mesParams.getJSONArray("manufacturingOrderMatIssuesList");
		Long manufacturingOrderId = mesParams.getLongValue("manufacturingOrderId");
		ManufacturingOrder manufacturingOrder = manufacturingOrderService.selectById(manufacturingOrderId);
		List<ManufacturingOrderMatIssue> manufacturingOrderMatIssues = manufacturingOrderMatIssueMapper.selectList(
				Wrappers.<ManufacturingOrderMatIssue>lambdaQuery().eq(ManufacturingOrderMatIssue::getMoId, manufacturingOrderId)
		);
		manufacturingOrderMatIssues.forEach(manufacturingOrderMatIssue -> {
			if (manufacturingOrderMatIssue.getStockId() != null) {
				stockUtils.updateById(manufacturingOrderMatIssue.getStockId(), manufacturingOrderMatIssue.getQtyIssue(), BigDecimal.ZERO, BigDecimal.ZERO, BigDecimal.ZERO, manufacturingOrder.getMoNo(), "MOMATUNISSUE");
			}
		});
		manufacturingOrderMatIssueMapper.delete(Wrappers.<ManufacturingOrderMatIssue>lambdaQuery().eq(ManufacturingOrderMatIssue::getMoId, manufacturingOrderId));
	}

	/**
	 * 车间订单状态修改和预处理参数参数拼接
	 *
	 * @param ifsLog
	 */
	private void updateManufacturingOrderState(IfsLog ifsLog) {
		JSONObject mesParams = JSONObject.parseObject(ifsLog.getMesParams());
		JSONArray manufacturingOrderArr = mesParams.getJSONArray("manufacturingOrderArr");
		String sysmodel = mesParams.getString("SYSMODEL");
		JSONObject params = new JSONObject()
				.fluentPut("RECORD_ID", UUID.randomUUID().toString())
				.fluentPut("SYSCODE", "LMES")
				.fluentPut("SYSMODEL", sysmodel);
		JSONArray jsonArray = new JSONArray();
		for (int i = 0; i < manufacturingOrderArr.size(); i++) {
			//解析数据
			JSONObject jsonObject = manufacturingOrderArr.getJSONObject(i);
			//查询车间订单
			ManufacturingOrder manufacturingOrder = manufacturingOrderService.selectById(jsonObject.getLong("moId"));
			jsonObject.put("ORDER_NO", manufacturingOrder.getIfsOrderNo());//订单编号
			jsonObject.put("RELEASE_NO", manufacturingOrder.getIfsReleaseNo());//下达号
			jsonObject.put("SEQUENCE_NO", manufacturingOrder.getIfsSequenceNo());//序列号
			jsonObject.remove("moId");
			jsonArray.add(jsonObject);
		}
		params.put("BATCH_INFO", jsonArray);
		// 更新缓存参数
		IfsLog update = new IfsLog();
		update.setId(ifsLog.getId());
		update.setInAttr(params.toJSONString());
		ifsLogMapper.updateById(update);
	}


	/**
	 * 更新取消报工请求ifs参数
	 *
	 * @param ifsLog
	 */
	private void updateUnReportParams(IfsLog ifsLog) {
		Long productMainId = JSONObject.parseObject(ifsLog.getMesParams()).getLongValue("productMainId");
		List<ProductMainIfsReport> productMainIfsReports = productMainIfsReportMapper.selectList(Wrappers.<ProductMainIfsReport>lambdaQuery().eq(ProductMainIfsReport::getProductMainId, productMainId));
		JSONObject params = new JSONObject();
		params.put("RECORD_ID", UUID.randomUUID().toString().replace("-", ""));
		params.put("SYSCODE", "L-MES");
		params.put("SYSMODEL", "报工单取消工序报工");
		JSONArray jsonArray = new JSONArray();
		for (ProductMainIfsReport productMainIfsReport : productMainIfsReports) {
			JSONObject opfeed = new JSONObject();
			opfeed.put("TRANSACTION_ID", productMainIfsReport.getIfsOpfeedId());
			JSONObject labor = new JSONObject();
			labor.put("TRANSACTION_ID", productMainIfsReport.getIfsLaborId());
			jsonArray.add(opfeed);
			jsonArray.add(labor);
		}
		params.put("BATCH_INFO", jsonArray);
		// 更新缓存参数
		IfsLog update = new IfsLog();
		update.setId(ifsLog.getId());
		update.setInAttr(params.toJSONString());
		ifsLogMapper.updateById(update);
	}

	/**
	 * 更新ifs工序报工返回的报工id
	 *
	 * @param data
	 * @param mesParams
	 */
	private void updateReportResult(JSONObject data, JSONObject mesParams) {
		// 保存ifs工序报告id和人工id，用于取消
		JSONArray reportInfosList = data.getJSONArray("REPORT_INFOS");
		for (int i = 0; i < reportInfosList.size(); i++) {
			JSONArray reportInfo = reportInfosList.getJSONObject(i).getJSONArray("REPORT_INFO");
			if (CollectionUtil.isNotEmpty(reportInfo)) {
				Long ifsOpfeedId = null;
				Long ifsLaborId = null;
				for (int j = 0; j < reportInfo.size(); j++) {
					if (reportInfo.getJSONObject(j).getString("TRANSACTION_CODE").equals("OPFEED")) {
						ifsOpfeedId = reportInfo.getJSONObject(j).getLongValue("TRANSACTION_ID");
					} else {
						ifsLaborId = reportInfo.getJSONObject(j).getLongValue("TRANSACTION_ID");
					}
				}
				ProductMainIfsReport productMainIfsReport = new ProductMainIfsReport();
				productMainIfsReport.setProductMainId(mesParams.getLongValue("productMainId"));
				productMainIfsReport.setIfsOpfeedId(ifsOpfeedId);
				productMainIfsReport.setIfsLaborId(ifsLaborId);
				productMainIfsReportMapper.insert(productMainIfsReport);
			}
		}
	}

	/**
	 * 更新ifs工序报工返回的报工id（检测汇报）
	 *
	 * @param data
	 * @param mesParams
	 */
	private void updateTestReportResult(JSONObject data, JSONObject mesParams) {
		// 保存ifs工序报告id和人工id，用于取消
		JSONArray reportInfosList = data.getJSONArray("REPORT_INFOS");
		for (int i = 0; i < reportInfosList.size(); i++) {
			JSONArray reportInfo = reportInfosList.getJSONObject(i).getJSONArray("REPORT_INFO");
			if (CollectionUtil.isNotEmpty(reportInfo)) {
				Long ifsOpfeedId = null;
				Long ifsLaborId = null;
				for (int j = 0; j < reportInfo.size(); j++) {
					if (reportInfo.getJSONObject(j).getString("TRANSACTION_CODE").equals("OPFEED")) {
						ifsOpfeedId = reportInfo.getJSONObject(j).getLongValue("TRANSACTION_ID");
					} else {
						ifsLaborId = reportInfo.getJSONObject(j).getLongValue("TRANSACTION_ID");
					}
				}
				QualityMainIfsReport qualityMainIfsReport = new QualityMainIfsReport();
				qualityMainIfsReport.setQualityReportId(mesParams.getLongValue("qualityReportId"));//检测汇报id
				qualityMainIfsReport.setIfsOpfeedId(ifsOpfeedId);
				qualityMainIfsReport.setIfsLaborId(ifsLaborId);
				qualityMainIfsReportMapper.insert(qualityMainIfsReport);
			}
		}
	}

	/**
	 * 更新取消报工请求ifs参数（检测汇报）
	 *
	 * @param ifsLog
	 */
	private void updateUnTestReportParams(IfsLog ifsLog) {
		Long qualityReportId = JSONObject.parseObject(ifsLog.getMesParams()).getLongValue("qualityReportId");
		List<QualityMainIfsReport> qualityMainIfsReports = qualityMainIfsReportMapper.selectList(Wrappers.<QualityMainIfsReport>lambdaQuery().eq(QualityMainIfsReport::getQualityReportId, qualityReportId));
		JSONObject params = new JSONObject();
		params.put("RECORD_ID", UUID.randomUUID().toString().replace("-", ""));
		params.put("SYSCODE", "L-MES");
		params.put("SYSMODEL", "检测汇报取消工序报工");
		JSONArray jsonArray = new JSONArray();
		for (QualityMainIfsReport qualityMainIfsReport : qualityMainIfsReports) {
			JSONObject opfeed = new JSONObject();
			opfeed.put("TRANSACTION_ID", qualityMainIfsReport.getIfsOpfeedId());
			JSONObject labor = new JSONObject();
			labor.put("TRANSACTION_ID", qualityMainIfsReport.getIfsLaborId());
			jsonArray.add(opfeed);
			jsonArray.add(labor);
		}
		params.put("BATCH_INFO", jsonArray);
		// 更新缓存参数
		IfsLog update = new IfsLog();
		update.setId(ifsLog.getId());
		update.setInAttr(params.toJSONString());
		ifsLogMapper.updateById(update);
	}
}