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

import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.chinaztt.mes.basic.entity.Part;
import com.chinaztt.mes.basic.mapper.PartMapper;
import com.chinaztt.mes.production.service.CommonService;
import com.chinaztt.mes.quality.dto.ApplyDTO;
import com.chinaztt.mes.quality.dto.ApplyPartDTO;
import com.chinaztt.mes.quality.entity.Apply;
import com.chinaztt.mes.quality.service.ApplyService;
import com.chinaztt.mes.warehouse.dto.EscortDTO;
import com.chinaztt.mes.warehouse.dto.EscortDetailDTO;
import com.chinaztt.mes.warehouse.dto.SendBackDTO;
import com.chinaztt.mes.warehouse.dto.StockAddDTO;
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.SendBackMapper;
import com.chinaztt.mes.warehouse.mapper.StockMapper;
import com.chinaztt.mes.warehouse.service.impl.EscortServiceImpl;
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 lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

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


/**
 * @author zhangxy
 */
@Slf4j
@Service
@AllArgsConstructor
@Transactional(rollbackFor = Exception.class)
public class CommonServiceImpl implements CommonService {

	private EscortServiceImpl escortService;
	private EscortDetailMapper escortDetailMapper;
	private EscortMapper escortMapper;
	private StockUtils stockUtils;
	private StockMapper stockMapper;
	private PartMapper partMapper;
	private ApplyService applyService;
	private SendBackMapper sendBackMapper;


	@Override
	public R fullSave(SendBackDTO sendBackDTO) {
		if (CollectionUtil.isNotEmpty(sendBackDTO.getEscortList())) {
			for (EscortDetailDTO escortDetailDTO : sendBackDTO.getEscortList()) {
				sendBackDTO.setEscortDetailId(escortDetailDTO.getId());
				sendBackDTO.setPartNo(escortDetailDTO.getPartNo());
				sendBackDTO.setPartName(escortDetailDTO.getPartName());
				sendBackDTO.setPartBatchNo(escortDetailDTO.getPartBatchNo());
				sendBackDTO.setSystemNo(escortDetailDTO.getSystemNo());
				sendBackDTO.setPartUnit(escortDetailDTO.getPartUnit());
				sendBackDTO.setSendBackLocationId(sendBackDTO.getSendBackLocationId());
				sendBackDTO.setSendBackLocationName(sendBackDTO.getSendBackLocationName());
				sendBackDTO.setStatus("02completed");
				sendBackMapper.insert(sendBackDTO);

				//进行移库  库位一样就增加数量   不然在这个库位新增数量  库位号 零件批号 系统编号确定唯一
				Stock stock = stockMapper.selectById(escortDetailDTO.getStockId());
				Long stockId = escortDetailDTO.getStockId();
				List<Part> parts = partMapper.selectList(Wrappers.<Part>lambdaQuery()
						.eq(Part::getPartNo, escortDetailDTO.getPartNo()).orderByDesc(Part::getId));
				if (CollectionUtil.isEmpty(parts)) {
					throw new RuntimeException("缺少" + escortDetailDTO.getPartNo() + "的零件");
				}
				Part part = parts.get(0);
				if (null == sendBackDTO.getSendBackLocationId()) {
					throw new RuntimeException("缺少库位");
				}
				if (!stock.getLocationId().equals(sendBackDTO.getSendBackLocationId())) {
//					stockUtils.updateById(escortDetailDTO.getStockId(), sendBackDTO.getSendBackQuantity(), BigDecimal.ZERO
//							, escortDetailDTO.getEscortNo(), TransactionType.SALES_ORDER_RETURNS.getValue());
//				}else{ //新增库存记录
					StockAddDTO stockAdd = new StockAddDTO();
					stockAdd.setPartsId(part.getId());
					stockAdd.setNewLocationId(sendBackDTO.getSendBackLocationId());
					stockAdd.setNewPartBatchNo(escortDetailDTO.getPartBatchNo());
					stockAdd.setNewSystemNo(escortDetailDTO.getSystemNo());
					stockAdd.setReelNumber(stock.getReelNumber());

					Stock stockNew = stockUtils.query(stockAdd);
					stockId = stockNew.getId();
				}
				stockUtils.updateById(stockId, sendBackDTO.getSendBackQuantity(), BigDecimal.ZERO, BigDecimal.ZERO, BigDecimal.ZERO
						, escortDetailDTO.getEscortNo(), TransactionType.SALES_ORDER_RETURNS.getValue());

				//生成 检测申请
				ApplyDTO applyDTO = new ApplyDTO();
				applyDTO.setApplyType(Apply.BACK_APPLY);
				applyDTO.setRemark("退货报检");

				List<ApplyPartDTO> applyPartList = new ArrayList<ApplyPartDTO>();
				ApplyPartDTO applyPartDTO = new ApplyPartDTO();
				applyPartDTO.setSystemNo(escortDetailDTO.getSystemNo());
				applyPartDTO.setPartNo(escortDetailDTO.getPartNo());
				applyPartDTO.setPartName(escortDetailDTO.getPartName());
				applyPartDTO.setQtyArrived(sendBackDTO.getSendBackQuantity().toPlainString());
				applyPartDTO.setLotBatchNo(escortDetailDTO.getPartBatchNo());
				applyPartDTO.setPartId(part.getId());
				applyPartList.add(applyPartDTO);
				applyDTO.setApplyPartList(applyPartList);
				applyService.saveDto(applyDTO);


				//同步gsm 删除发货 入库
				EscortDetail escortDetail = escortDetailMapper.selectById(sendBackDTO.getEscortDetailId());
				EscortDTO escortDTO = new EscortDTO();
				if (escortDetail != null) {
					Escort escort = escortMapper.selectById(escortDetail.getEscortId());
					BeanUtils.copyProperties(escort, escortDTO);
				}
				try {
//					escortService.deleteOutStorage(escortDTO, escortDetail);
					escortService.deleteInStorage(escortDTO, escortDetail);
				} catch (Exception e) {
					log.error("退货失败：" + e.getMessage());
					log.error("退货失败：sendBackDTO" + sendBackDTO);
					e.printStackTrace();
				}
			}
		} else {
			return R.failed("没有选择已完成发货的明细");
		}
		return R.ok();
	}
}