package com.chinaztt.mes.warehouse.service.impl;

import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.date.DatePattern;
import cn.hutool.core.date.DateUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
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.gsm.in.InStorageService;
import com.chinaztt.mes.common.gsm.in.InStorageSingleDeleteModel;
import com.chinaztt.mes.common.gsm.out.OutStorageService;
import com.chinaztt.mes.common.gsm.out.OutStorageSingleDeleteModel;
import com.chinaztt.mes.common.handler.StateMachineHandler;
import com.chinaztt.mes.common.numgen.NumberGenerator;
import com.chinaztt.mes.common.util.StateResult;
import com.chinaztt.mes.warehouse.dto.EscortDTO;
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.entity.Stock;
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.service.EscortService;
import com.chinaztt.mes.warehouse.state.escort.EscortStateMachineConfig;
import com.chinaztt.mes.warehouse.state.escort.constant.EscortEvents;
import com.chinaztt.mes.warehouse.state.escort.constant.EscortStates;
import com.chinaztt.mes.warehouse.util.StockUtils;
import com.chinaztt.mes.warehouse.util.TransactionType;
import com.chinaztt.ztt.common.core.util.R;
import lombok.AllArgsConstructor;
import org.dom4j.Document;
import org.dom4j.DocumentHelper;
import org.dom4j.Element;
import org.springframework.messaging.Message;
import org.springframework.messaging.support.MessageBuilder;
import org.springframework.statemachine.config.StateMachineFactory;
import org.springframework.statemachine.persist.StateMachinePersister;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.transaction.interceptor.TransactionAspectSupport;
import org.springframework.util.CollectionUtils;

import java.math.BigDecimal;
import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.List;
import java.util.Optional;
import java.util.stream.Collectors;

/**
 * 押运单主表
 *
 * @author cxf
 * @date 2021-07-23 14:32:00
 */
@Service
@AllArgsConstructor
@Transactional(rollbackFor = Exception.class)
public class EscortServiceImpl extends ServiceImpl<EscortMapper, Escort> implements EscortService {
	private NumberGenerator<Escort> reportNumberGenerator;
	private StateMachineFactory<EscortStates, EscortEvents> escortStateMachineFactory;
	private StateMachinePersister<EscortStates, EscortEvents, Escort> persister;
	private EscortDetailMapper escortDetailMapper;
	private StockUtils stockUtils;
	@Override
	public List<EscortDetailDTO> exportList(QueryWrapper<EscortDetailDTO> gen) {
		return escortDetailMapper.exportList(gen);
	}

	@Override
	public List<Escort> getEscortInfoByOrder(List<Long> customerOrderIds) {
		return baseMapper.getEscortInfoByOrder(customerOrderIds);
	}

	@Override
	public boolean saveDto(EscortDTO escort) {
		try {// 1.保存主表
			checkEscortNo(escort);
			baseMapper.insert(escort);
			// 2.保存发货明细
			if (CollectionUtil.isNotEmpty(escort.getEscortDetailList())) {
				escort.getEscortDetailList().stream().forEach(escortDetail -> {
					escortDetail.setEscortId(escort.getId());
					escortDetailMapper.insert(escortDetail);
					stockUtils.updateById(escortDetail.getStockId(), BigDecimal.ZERO, escortDetail.getDeliveryQty(), BigDecimal.ZERO, BigDecimal.ZERO, null, TransactionType.ESCORT_RESERVED.getValue());
				});
			}
		} catch (Exception ex) {
			TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
			throw new RuntimeException(ex.getMessage());
		}
		return true;
	}

	@Override
	public boolean updateDtoById(EscortDTO escort) {
		try {// 1.更新主表
			checkEscortNo(escort);
			baseMapper.updateById(escort);
			//修改 可能会新增发货明细 也可能删除  更改发货明细 相应的完成的时候需要判断 是否有gsm入库出库记录 没的话不需要删除 直接调gsm新增
			// 2.先删除后保存发货明细

			//找出前台删除的详情数据
			List<EscortDetail> databaseEscortDetails = escortDetailMapper.selectList(Wrappers.<EscortDetail>lambdaQuery()
					.eq(EscortDetail::getEscortId, escort.getId()));
			List<EscortDetail> deleteEscortDetails = new ArrayList<>();
			List<EscortDetail> updateEscortDetails = new ArrayList<>();
			List<Long> oldEscortDetailIds = escort.getEscortDetailList().stream()
					.filter(el -> null != el.getId()).map(EscortDetail::getId).collect(Collectors.toList());

			databaseEscortDetails.stream().forEach(e -> {
				if (!oldEscortDetailIds.contains(e.getId())) {
					deleteEscortDetails.add(e);
				}else{
					updateEscortDetails.add(e);
				}
			});
			if (!deleteEscortDetails.isEmpty()) {
				escortDetailMapper.deleteBatchIds(deleteEscortDetails.stream().map(EscortDetail::getId).collect(Collectors.toList()));
				//取消预留
				for(EscortDetail deleteEscortDetail:deleteEscortDetails){
					stockUtils.updateById(deleteEscortDetail.getStockId(), BigDecimal.ZERO, deleteEscortDetail.getDeliveryQty().negate(),  BigDecimal.ZERO, BigDecimal.ZERO,null, TransactionType.ESCORT_CANCEL_RESERVED.getValue());
				}
			}
			if (CollectionUtil.isNotEmpty(escort.getEscortDetailList())) {
				escort.getEscortDetailList().forEach(escortDetail -> {
					if (escortDetail.getId() != null) {
						escortDetailMapper.activeById(escortDetail.getId());
						escortDetailMapper.updateById(escortDetail);
						//更新时，先取消预留，再进行预留
						Optional<EscortDetail> updateEscortDetailOptional=updateEscortDetails.stream()
								.filter(el -> escortDetail.getId()== el.getId()).findFirst();
						if(updateEscortDetailOptional.isPresent()){
							//存在
							EscortDetail updateEscortDetail=updateEscortDetailOptional.get();
							//取消预留
							stockUtils.updateById(updateEscortDetail.getStockId(), BigDecimal.ZERO, updateEscortDetail.getDeliveryQty().negate(),  BigDecimal.ZERO, BigDecimal.ZERO,null, TransactionType.ESCORT_CANCEL_RESERVED.getValue());
						}
						//预留
						stockUtils.updateById(escortDetail.getStockId(), BigDecimal.ZERO, escortDetail.getDeliveryQty(),  BigDecimal.ZERO, BigDecimal.ZERO,null, TransactionType.ESCORT_RESERVED.getValue());
					} else {
						escortDetail.setEscortId(escort.getId());
						escortDetailMapper.insert(escortDetail);
						//预留
						stockUtils.updateById(escortDetail.getStockId(), BigDecimal.ZERO, escortDetail.getDeliveryQty(),  BigDecimal.ZERO, BigDecimal.ZERO,null, TransactionType.ESCORT_RESERVED.getValue());
					}
				});
			} else {
				baseMapper.deleteById(escort.getId());
			}
		} catch (Exception ex) {
			ex.printStackTrace();
		}
		return true;
	}

	/**
	 * 删除GSM的入库记录
	 *
	 * @param escort
	 * @param escortDetail
	 */
	public void deleteInStorage(EscortDTO escort, EscortDetail escortDetail) throws Exception {
		//查找发货绑定的客户订单的GSM的合同产品id
		Long id = getBaseMapper().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 + "请手动删除");
				}
			}
		}
	}

	private void checkEscortNo(Escort escort) {
		if (StringUtils.isBlank(escort.getEscortNo())) {
			// 1. 自动生成编号
			escort.setEscortNo(reportNumberGenerator.generateNumberWithPrefix(Escort.DIGIT,
					Escort.PREFIX + DateUtil.format(LocalDateTime.now(), DatePattern.PURE_DATE_PATTERN) + "-", Escort::getEscortNo));
		} else {
			// 2.判断是否重复
			List<Escort> repeatNos = baseMapper.selectList(Wrappers.<Escort>query().lambda().eq(Escort::getEscortNo, escort.getEscortNo()).ne(Escort::getId, escort.getId()));
			if (CollectionUtil.isNotEmpty(repeatNos)) {
				throw new RuntimeException("编号重复");
			}
		}
	}

	@Override
	public R<Boolean> changeState(List<Escort> escortList, String event) {
		for (Escort escort : escortList) {
			Message<EscortEvents> message = MessageBuilder.withPayload(EscortEvents.valueOf(event)).setHeader("escort", escort).build();
			StateMachineHandler handler = new StateMachineHandler(escortStateMachineFactory, persister, EscortStateMachineConfig.MACHINE_ID, escort);
			StateResult res = handler.sendEvent(message, escort.getId());
			if (!res.isSuccess()) {
				throw new RuntimeException(res.getMsg());
			}
		}
		return R.ok();
	}

	/**
	 * 删除GSM的出库记录
	 *
	 * @param escort
	 * @param escortDetail
	 */
	public void deleteOutStorage(EscortDTO escort, EscortDetail escortDetail) throws Exception {
		//查找发货绑定的客户订单的GSM的合同行号
		Long id = getBaseMapper().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 + "请手动删除");
				}
			}
		}
	}

	@Override
	public IPage<EscortDetailDTO> getEscortDetailListComplete(Page page, QueryWrapper<EscortDetailDTO> gen) {
		return escortDetailMapper.getEscortDetailListComplete(page, gen);
	}

	@Override
	public List<EscortDetailDTO> getEscortDetailList(QueryWrapper<EscortDetailDTO> gen) {
		return escortDetailMapper.getEscortDetailList(gen);
	}


	@Override
	public boolean delById(Long id) {
		List<EscortDetail> escortDetails = escortDetailMapper.selectList(Wrappers.<EscortDetail>lambdaQuery().eq(EscortDetail::getEscortId, id));
		if (!CollectionUtils.isEmpty(escortDetails)) {
			throw new RuntimeException("存在押运单明细不可删除");
		}
		getBaseMapper().deleteById(id);
		return true;
	}

	@Override
	public boolean delDetailsByIds(List<Long> ids) {
		try{
			EscortDetail escortDetail =null;
			for(Long escortDetailId:ids){
				escortDetail = escortDetailMapper.selectById(escortDetailId);
				escortDetailMapper.deleteById(escortDetailId);
				//预留库存需返还
				stockUtils.updateById(escortDetail.getStockId(), BigDecimal.ZERO, escortDetail.getDeliveryQty().negate(),  BigDecimal.ZERO, BigDecimal.ZERO,null, TransactionType.ESCORT_CANCEL_RESERVED.getValue());
			}

		} catch (Exception ex) {
			TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
			throw new RuntimeException(ex.getMessage());
		}
		return true;
	}

}