package com.chinaztt.mes.warehouse.state.escort;

import cn.hutool.core.collection.CollectionUtil;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.chinaztt.mes.common.gsm.escort.EscortServiceGsm;
import com.chinaztt.mes.common.gsm.escort.EscortSingleAddModel;
import com.chinaztt.mes.common.gsm.escort.EscortSingleDeleteModel;
import com.chinaztt.mes.common.gsm.in.InStorageService;
import com.chinaztt.mes.common.gsm.in.InStorageSingleAddModel;
import com.chinaztt.mes.common.gsm.in.InStorageSingleDeleteModel;
import com.chinaztt.mes.common.gsm.out.OutStorageService;
import com.chinaztt.mes.common.gsm.out.OutStorageSingleAddModel;
import com.chinaztt.mes.common.gsm.out.OutStorageSingleDeleteModel;
import com.chinaztt.mes.common.handler.StateMachineHandler;
import com.chinaztt.mes.common.wrapper.QueryWrapperUtil;
import com.chinaztt.mes.warehouse.dto.EscortDetailDTO;
import com.chinaztt.mes.warehouse.entity.Escort;
import com.chinaztt.mes.warehouse.entity.EscortDetail;
import com.chinaztt.mes.warehouse.mapper.EscortDetailMapper;
import com.chinaztt.mes.warehouse.mapper.EscortMapper;
import com.chinaztt.mes.warehouse.mapper.JoinStockOrderMapper;
import com.chinaztt.mes.warehouse.state.escort.constant.EscortEvents;
import com.chinaztt.mes.warehouse.state.escort.constant.EscortStateStringValues;
import com.chinaztt.mes.warehouse.util.StockUtils;
import com.chinaztt.mes.warehouse.util.TransactionType;
import lombok.AllArgsConstructor;
import org.dom4j.Document;
import org.dom4j.DocumentHelper;
import org.dom4j.Element;
import org.springframework.messaging.Message;
import org.springframework.statemachine.StateMachine;
import org.springframework.statemachine.annotation.OnTransition;
import org.springframework.statemachine.annotation.WithStateMachine;
import org.springframework.stereotype.Component;

import java.math.BigDecimal;
import java.time.format.DateTimeFormatter;
import java.util.List;


/**
 * @Author: cxf
 * @Date: 2020-07-24 9:51
 */
@AllArgsConstructor
@Component
@WithStateMachine(id = "escortStateMachine")
public class EscortStateListener {
	private StockUtils stockUtils;
	private EscortMapper escortMapper;
	private EscortDetailMapper escortDetailMapper;
	private JoinStockOrderMapper joinStockOrderMapper;


	/**
	 * 完成
	 */
	@OnTransition(source = EscortStateStringValues.DRAFT, target = EscortStateStringValues.COMPLETED)
	public boolean complete(StateMachine stateMachine, Message<EscortEvents> msg) {
		Escort escort = (Escort) msg.getHeaders().get("escort");
		// 1.更新状态
		escort.setStatus(EscortStateStringValues.COMPLETED);
		escortMapper.updateById(escort);
		// 2.更新实时库存和预留数量
		EscortDetailDTO escortDetail = new EscortDetailDTO();
		escortDetail.setEscortId(escort.getId());
		List<EscortDetailDTO> detailList = escortDetailMapper.getEscortDetailList(QueryWrapperUtil.gen(escortDetail));
//		boolean isFirstCompleted =  (null == escort.getEscortAutoId()) ; //区分是否首次点击完成 同步gsm  是的话 同步即可 如果是非首次 需要先删除 后新增
//		StringBuffer escortOutAutoId = new StringBuffer();
//		String outAutoIdStr = null;
		if (CollectionUtil.isNotEmpty(detailList)) {
			for (EscortDetailDTO detail : detailList) {
				try {
					stockUtils.updateById(detail.getStockId(), detail.getDeliveryQty().negate(), detail.getDeliveryQty()
							.negate(), BigDecimal.ZERO, BigDecimal.ZERO, escort.getEscortNo(), TransactionType.SALES_ORDER_DELIVERY.getValue());
					//同步gsm
					//调用GSM入库并把入库的id同步到mes系统中
//					long inAutoId =syncGsmIn(escort,detail);
//					detail.setEscortInAutoId(inAutoId);
//					escortDetailMapper.updateById(detail);
//					//调用GSM的发货新增并把发货的id同步到mes系统中
//					long outAutoId = syncGsmOut(escort,detail);
//					detail.setEscortOutAutoId(outAutoId);
//					escortDetailMapper.updateById(detail);
//					//拼接GSM发货id
//					escortOutAutoId.append(outAutoId).append(",");
				} catch (RuntimeException e) {
					stateMachine.getExtendedState().getVariables().put(StateMachineHandler.ERROR_KEY, escort.getEscortNo()
							+ "#" + detail.getPartBatchNo() + "：" + e.getMessage());
					return false;
				}
			}
//			outAutoIdStr = escortOutAutoId.deleteCharAt(escortOutAutoId.length() - 1).toString();
		}
		//调用押运单的同步
//		long escortAutoId = syncGsmEscort(escort,outAutoIdStr);
		//将返回的GSM押运单的id存到mes的押运单中
//		escort.setEscortAutoId(escortAutoId);
		escortMapper.updateById(escort);
		// 3.更新发货数量
		updateDeliveryQuantity(escort.getId(), "+");
		//同步gsm
		// 2.保存发货明细
//		StringBuffer escortOutAutoId = new StringBuffer();

//		try {
////			if(!isFirstCompleted){
////				deleteEscortStorage(escort);
////			}
//			if (CollectionUtil.isNotEmpty(detailList)) {
//				for (EscortDetailDTO escortDetailEn: detailList) {
////					if(!isFirstCompleted){ //非首次确定同步  需要先删除 后新增
////						deleteOutStorage(escort,escortDetailEn);
////						deleteInStorage(escort,escortDetailEn);
////					}
//					//调用GSM入库并把入库的id同步到mes系统中
//					long inAutoId =syncGsmIn(escort,escortDetailEn);
//					escortDetailEn.setEscortInAutoId(inAutoId);
//					escortDetailMapper.updateById(escortDetailEn);
//					//调用GSM的发货新增并把发货的id同步到mes系统中
//					long outAutoId = syncGsmOut(escort,escortDetailEn);
//					escortDetailEn.setEscortOutAutoId(outAutoId);
//					escortDetailMapper.updateById(escortDetailEn);
//					//拼接GSM发货id
//					escortOutAutoId.append(outAutoId).append(",");
//				}
//			}
//			String outAutoIdStr = escortOutAutoId.deleteCharAt(escortOutAutoId.length() - 1).toString();
//			//调用押运单的同步
//			long escortAutoId = syncGsmEscort(escort,outAutoIdStr);
////			//将返回的GSM押运单的id存到mes的押运单中
//			escort.setEscortAutoId(escortAutoId);
//			escortMapper.updateById(escort);
//		} catch (Exception e) {
//			e.printStackTrace();
//			stateMachine.getExtendedState().getVariables().put(StateMachineHandler.ERROR_KEY, escort.getEscortNo()
//					+ "#"  + "：" + e.getMessage());
//			return false;
//		}
		return true;
	}

	/**
	 * 取消
	 * 同步gsm删除
	 *
	 * @param stateMachine
	 * @param msg
	 * @return
	 */
	@OnTransition(source = EscortStateStringValues.COMPLETED, target = EscortStateStringValues.DRAFT)
	public boolean cancel(StateMachine stateMachine, Message<EscortEvents> msg) {
		Escort escort = (Escort) msg.getHeaders().get("escort");
		// 1.更新状态
		escort.setStatus(EscortStateStringValues.DRAFT);
		escortMapper.updateById(escort);
		// 2.更新实时库存和预留数量
		EscortDetailDTO escortDetail = new EscortDetailDTO();
		escortDetail.setEscortId(escort.getId());
		List<EscortDetailDTO> detailList = escortDetailMapper.getEscortDetailList(QueryWrapperUtil.gen(escortDetail));
		try {
//			deleteEscortStorage(escort);
			if (CollectionUtil.isNotEmpty(detailList)) {
				for (EscortDetailDTO detail : detailList) {
					stockUtils.updateById(detail.getStockId(), detail.getDeliveryQty(), detail.getDeliveryQty(), BigDecimal.ZERO, BigDecimal.ZERO, escort.getEscortNo(), TransactionType.CANCEL_SALES_ORDER_DELIVERY.getValue());

					//同步gsm
//					deleteOutStorage(escort, detail);
//					deleteInStorage(escort, detail);
				}
			}
		} catch (Exception e) {
			stateMachine.getExtendedState().getVariables().put(StateMachineHandler.ERROR_KEY
					, escort.getEscortNo() + "#" + "：" + e.getMessage());
			return false;
		}
		// 3.更新发货数量
		updateDeliveryQuantity(escort.getId(), "-");
		return true;
	}

	public synchronized void updateDeliveryQuantity(Long escortId, String plusOrMinus) {
		escortMapper.updateStockOrderById(escortId, plusOrMinus);
		escortMapper.updateCustomerOrderById(escortId);
	}


	/**
	 * 删除GSM的押运单
	 *
	 * @param escort
	 */
	public void deleteEscortStorage(Escort escort) throws Exception {
		String inAutoId = String.valueOf(escort.getEscortAutoId());
		if (!StringUtils.isEmpty(inAutoId)) {
			EscortServiceGsm escortServiceGsm = new EscortServiceGsm();
			EscortSingleDeleteModel escortSingleDeleteModel = new EscortSingleDeleteModel();
			escortSingleDeleteModel.setSalesServiceKey("5CEa1840tB4D8e83E1BA886FE42a60C7");
			escortSingleDeleteModel.setID(inAutoId);
			escortSingleDeleteModel.setEscortNo(escort.getEscortNo());
			escortSingleDeleteModel.setEntryPeople(StringUtils.isBlank(escort.getSalesman()) ? "1" : escort.getSalesman());
			escortSingleDeleteModel.setEntryPeopleWorkCode(escort.getSalesmanWorkCode() == null ? "1" : escort.getSalesmanWorkCode());
			escortSingleDeleteModel.setIsJosn("0");

			Document deleteDocument = DocumentHelper.parseText(escortServiceGsm.getEscortServiceSoap().singleDelete(escortSingleDeleteModel));
			Element deleteRootElement = deleteDocument.getRootElement();
			//错误代码
			String inErrorCode = deleteRootElement.element("miap_header").element("errorcode").getText();
			if (!inErrorCode.equals("0")) {
				//获取错误信息
				String deleteErrorMessage = deleteRootElement.element("miap_header").element("errormsg").getText();
				//抛出错误
				if (!inErrorCode.equals("90") && !inErrorCode.equals("88") && !inErrorCode.equals("89") && !inErrorCode.equals("87")) {
					throw new RuntimeException("GSM入库记录删除失败，原因：" + deleteErrorMessage + "请手动删除");
				}
			}
		}
	}

	/**
	 * 删除GSM的出库记录
	 *
	 * @param escort
	 * @param escortDetail
	 */
	public void deleteOutStorage(Escort escort, EscortDetail escortDetail) throws Exception {
		//查找发货绑定的客户订单的GSM的合同产品id
		Long id = escortMapper.selectCustomerOrder(escort.getCustomerOrderId());
		//发货明细的出库id
		String outAutoId = escortDetail.getEscortOutAutoId().toString();
		if (!StringUtils.isEmpty(outAutoId)) {
			OutStorageService outStorageService = new OutStorageService();
			OutStorageSingleDeleteModel singleDeleteModel = new OutStorageSingleDeleteModel();
			singleDeleteModel.setSalesServiceKey("5CEa1840tB4D8e83E1BA886FE42a60C7");
			singleDeleteModel.setAutoID(outAutoId);
			singleDeleteModel.setContractid(escort.getCustomerOrderNo());
			singleDeleteModel.setContractInfoProductAutoID(String.valueOf(id));
			singleDeleteModel.setEntryPeople(StringUtils.isBlank(escort.getSalesman()) ? "1" : escort.getSalesman());
			singleDeleteModel.setEntryPeopleWorkCode(escort.getSalesmanWorkCode() == null ? "1" : escort.getSalesmanWorkCode());
			singleDeleteModel.setIsJosn("0");
			Document deleteDocument = DocumentHelper.parseText(outStorageService.getOutStorageServiceSoap().singleDelete(singleDeleteModel));
			Element deleteRootElement = deleteDocument.getRootElement();
			//错误代码
			String outErrorCode = deleteRootElement.element("miap_header").element("errorcode").getText();
			if (!outErrorCode.equals("0")) {
				//获取错误信息
				String deleteErrorMessage = deleteRootElement.element("miap_header").element("errormsg").getText();
				//抛出错误
				if (!outErrorCode.equals("90") && !outErrorCode.equals("88") && !outErrorCode.equals("89") && !outErrorCode.equals("87")) {
					throw new RuntimeException("GSM出库记录删除失败，原因：" + deleteErrorMessage + "请手动删除");
				}
			}
		}
	}

	/**
	 * 删除GSM的入库记录
	 *
	 * @param escort
	 * @param escortDetail
	 */
	public void deleteInStorage(Escort escort, EscortDetail escortDetail) throws Exception {
		//查找发货绑定的客户订单的GSM的合同产品id
		Long id = escortMapper.selectCustomerOrder(escort.getCustomerOrderId());
		String inAutoId = String.valueOf(escortDetail.getEscortInAutoId());
		if (!StringUtils.isEmpty(inAutoId)) {
			InStorageService inStorageService = new InStorageService();
			InStorageSingleDeleteModel singleDeleteModel = new InStorageSingleDeleteModel();
			singleDeleteModel.setSalesServiceKey("5CEa1840tB4D8e83E1BA886FE42a60C7");
			singleDeleteModel.setAutoID(inAutoId);
			singleDeleteModel.setContractid(escort.getCustomerOrderNo());
			singleDeleteModel.setContractInfoProductAutoID(String.valueOf(id));
			singleDeleteModel.setEntryPeople(StringUtils.isBlank(escort.getSalesman()) ? "1" : escort.getSalesman());
			singleDeleteModel.setEntryPeopleWorkCode(escort.getSalesmanWorkCode() == null ? "1" : escort.getSalesmanWorkCode());
			singleDeleteModel.setIsJosn("0");
			Document deleteDocument = DocumentHelper.parseText(inStorageService.getInStorageServiceSoap().singleDelete(singleDeleteModel));
			Element deleteRootElement = deleteDocument.getRootElement();
			//错误代码
			String inErrorCode = deleteRootElement.element("miap_header").element("errorcode").getText();
			if (!inErrorCode.equals("0")) {
				//获取错误信息
				String deleteErrorMessage = deleteRootElement.element("miap_header").element("errormsg").getText();
				//抛出错误
				if (!inErrorCode.equals("90") && !inErrorCode.equals("88") && !inErrorCode.equals("89") && !inErrorCode.equals("87")) {
					throw new RuntimeException("GSM入库记录删除失败，原因：" + deleteErrorMessage + "请手动删除");
				}
			}
		}
	}

	/**
	 * 同步GSM出库单
	 *
	 * @param escort
	 * @param escortDetail
	 * @return
	 */
	public long syncGsmOut(Escort escort, EscortDetail escortDetail) {
		//查找发货绑定的客户订单的GSM的合同产品id
		Long id = escortMapper.selectCustomerOrder(escort.getCustomerOrderId());
		OutStorageService outStorageService = new OutStorageService();
		OutStorageSingleAddModel outSingleAddModel = new OutStorageSingleAddModel();
		outSingleAddModel.setSalesServiceKey("5CEa1840tB4D8e83E1BA886FE42a60C7");
		outSingleAddModel.setContractid(escort.getCustomerOrderNo());
		outSingleAddModel.setContractInfoProductAutoID(String.valueOf(id));
		outSingleAddModel.setQualityQueryID(null);
		outSingleAddModel.setInstorageAutoID(String.valueOf(escortDetail.getEscortInAutoId()));
		if (escort.getEscortAutoId() != null) {
			outSingleAddModel.setEscortID(String.valueOf(escort.getEscortAutoId()));
		} else {
			outSingleAddModel.setEscortID(null);
		}
		outSingleAddModel.setEntryPeople("1");
		outSingleAddModel.setEntryPeopleWorkCode("1");
		outSingleAddModel.setQuantity(escortDetail.getDeliveryQty().toString());
		outSingleAddModel.setIsJosn("1");

		String res = outStorageService.getOutStorageServiceSoap().singleAdd(outSingleAddModel);
		JSONObject obj = JSONObject.parseObject(res);
		int errorcode = obj.getJSONObject("miap_header").getIntValue("errorcode");
		if (errorcode == 0) {
			return obj.getJSONObject("miap_Body").getLong("AutoID");
		} else {
			String msg = obj.getJSONObject("miap_header").getString("errormsg");
			throw new RuntimeException("GSM出库记录创建失败，原因：" + msg);
		}
	}

	/**
	 * 同步GSM入库单
	 *
	 * @param escort
	 * @return
	 */
	public long syncGsmIn(Escort escort, EscortDetail escortDetail) {
		//查找发货绑定的客户订单的GSM的合同产品id
		Long id = escortMapper.selectCustomerOrder(escort.getCustomerOrderId());
		//补充入库记录
		InStorageService inStorageService = new InStorageService();
		InStorageSingleAddModel singleAddModel = new InStorageSingleAddModel();
		singleAddModel.setSalesServiceKey("5CEa1840tB4D8e83E1BA886FE42a60C7");
		singleAddModel.setContractid(escort.getCustomerOrderNo());
		singleAddModel.setContractInfoProductAutoID(String.valueOf(id));
		singleAddModel.setEntryPeople("1");
		singleAddModel.setEntryPeopleWorkCode("1");
		singleAddModel.setQuantity(String.valueOf(escortDetail.getDeliveryQty()));
		singleAddModel.setIsJosn("1");

		String res = inStorageService.getInStorageServiceSoap().singleAdd(singleAddModel);
		JSONObject obj = JSONObject.parseObject(res);
		int errorcode = obj.getJSONObject("miap_header").getIntValue("errorcode");
		if (errorcode == 0) {
			return obj.getJSONObject("miap_Body").getLong("AutoID");
		} else {
			String msg = obj.getJSONObject("miap_header").getString("errormsg");
			throw new RuntimeException("GSM入库记录创建失败，原因：" + msg);
		}
	}


	/**
	 * 同步GSM押运单
	 *
	 * @param escort
	 * @param outAutoIdStr
	 * @return
	 */
	public long syncGsmEscort(Escort escort, String outAutoIdStr) {
		EscortServiceGsm escortService = new EscortServiceGsm();
		EscortSingleAddModel escortAddModel = new EscortSingleAddModel();
		//秘钥
		escortAddModel.setSalesServiceKey("5CEa1840tB4D8e83E1BA886FE42a60C7");
		//押运单号
		escortAddModel.setEscortNo(escort.getEscortNo());
		//承运商
		escortAddModel.setCarrier("111");
		//收货人
		escortAddModel.setReceiver(escort.getCustomerName());
		//收货地址
		escortAddModel.setAddress(escort.getAddress());
		//收货人联系电话
		escortAddModel.setPhone(escort.getPhone());
		DateTimeFormatter dateFormat = DateTimeFormatter.ofPattern("yyyy-MM-dd");
		//要求到货时间
		escortAddModel.setRequestDate(dateFormat.format(escort.getRequestDate()));
		//发货日期
		escortAddModel.setDeliveryDate("2021-10-16");
		//车牌号
		escortAddModel.setVehicleNo("1");
		//司机
		escortAddModel.setDriver("1");
		//司机电话
		escortAddModel.setDriverPhone("1");
		//检测报告份数
		escortAddModel.setTestCount("1");
		//合格证份数
		escortAddModel.setCertificateCount("1");
		//出厂报告份数
		escortAddModel.setOuterReportCount("1");
		//质保书份数
		escortAddModel.setQtyCount("1");
		//货物清单份数
		escortAddModel.setGoodsCount("1");
		//备注
		escortAddModel.setMarktext(escort.getRemark() == null ? "备注为空" : escort.getRemark());
		//录入人
		escortAddModel.setEntryPeople("1");
		//录入人编号
		escortAddModel.setEntryPeopleWorkCode("1");
		//发货的autoid
		escortAddModel.setOutStorageAuotoIDs(outAutoIdStr);
		//返回文件格式
		escortAddModel.setIsJosn("1");
		//合同号
		escortAddModel.setContractid(escort.getCustomerOrderNo());
		String res = escortService.getEscortServiceSoap().singleAdd(escortAddModel);
		JSONObject obj = JSONObject.parseObject(res);
		int errorcode = obj.getJSONObject("miap_header").getIntValue("errorcode");
		if (errorcode == 0) {
			return obj.getJSONObject("miap_Body").getLong("AutoID");
		} else {
			String msg = obj.getJSONObject("miap_header").getString("errormsg");
			throw new RuntimeException("GSM押运单创建失败，原因：" + msg);
		}
	}
}