/*
 *    Copyright (c) 2018-2025, ztt All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions are met:
 *
 * Redistributions of source code must retain the above copyright notice,
 * this list of conditions and the following disclaimer.
 * Redistributions in binary form must reproduce the above copyright
 * notice, this list of conditions and the following disclaimer in the
 * documentation and/or other materials provided with the distribution.
 * Neither the name of the pig4cloud.com developer nor the names of its
 * contributors may be used to endorse or promote products derived from
 * this software without specific prior written permission.
 * Author: ztt
 */
package com.chinaztt.mes.warehouse.service.impl;


import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.api.R;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.chinaztt.mes.basic.entity.Part;
import com.chinaztt.mes.basic.entity.Warehouse;
import com.chinaztt.mes.basic.mapper.PartMapper;
import com.chinaztt.mes.basic.util.BigDecimalUtils;
import com.chinaztt.mes.warehouse.dto.ValidateInventoryResultDTO;
import com.chinaztt.mes.warehouse.entity.InventoryDetail;
import com.chinaztt.mes.warehouse.entity.InventoryMain;
import com.chinaztt.mes.warehouse.entity.InventoryPda;
import com.chinaztt.mes.warehouse.entity.ProductOutput;
import com.chinaztt.mes.warehouse.mapper.InventoryDetailMapper;
import com.chinaztt.mes.warehouse.mapper.InventoryMainMapper;
import com.chinaztt.mes.warehouse.mapper.InventoryPdaMapper;
import com.chinaztt.mes.warehouse.mapper.ProductOutputMapper;
import com.chinaztt.mes.warehouse.service.InventoryDetailService;
import com.chinaztt.ztt.admin.api.entity.SysPublicParam;
import com.chinaztt.ztt.admin.api.feign.RemoteParamService;
import com.chinaztt.ztt.common.core.constant.SecurityConstants;
import lombok.AllArgsConstructor;
import lombok.Synchronized;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.math.BigDecimal;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.ArrayList;
import java.util.List;

/**
 * 新盘点明细
 *
 * @author yangyao
 * @date 2022-10-13 11:06:00
 */
@AllArgsConstructor
@Service
public class InventoryDetailServiceImpl extends ServiceImpl<InventoryDetailMapper, InventoryDetail> implements InventoryDetailService {


	private InventoryPdaMapper inventoryPdaMapper;

	private PartMapper partMapper;

	private InventoryMainMapper inventoryMainMapper;

	public static final String CHECK_INVENTORY_STATE = "CHECK_INVENTORY_STATE";//是否盘点中系统参数key

	public static final String INVENTORY_TIME = "INVENTORY_TIME";//盘点时间系统参数key

	private RemoteParamService remoteParamService;

	@Resource
	private ProductOutputMapper outputMapper;


	@Transactional(rollbackFor = Exception.class)
	@Override
	public boolean fullSave(InventoryDetail inventoryDetail) {
		InventoryDetail inventoryDetailBySelect = judgeBlankAndRepeat(inventoryDetail);
		//判断是否是盘点期间产出
		if(judgeIsInventoryTime(inventoryDetail.getSn())){
			throw new RuntimeException("盘点期间的产出冻结盘点操作");
		}

		if(inventoryDetailBySelect==null){
			InventoryDetail detail = getInventoryDetail(inventoryDetail);
			baseMapper.insert(detail);
			return true;
		}
		inventoryDetailBySelect.setInyQty(inventoryDetail.getInyQty().add(BigDecimalUtils.getBigDecimalValue(inventoryDetailBySelect.getInyQty())));
		inventoryDetailBySelect.setInyDiffQty(inventoryDetailBySelect.getStockQuantity().subtract(inventoryDetailBySelect.getInyQty()));
		baseMapper.updateById(inventoryDetailBySelect);
		return true;
	}


	public InventoryDetail judgeBlankAndRepeat(InventoryDetail inventoryDetail){
		if(StringUtils.isBlank(inventoryDetail.getPartNo())){
			throw new RuntimeException("零件号不能为空!");
		}
		if(StringUtils.isBlank(inventoryDetail.getSn())){
			throw new RuntimeException("Sn号不能为空!");
		}
		if(StringUtils.isBlank(inventoryDetail.getIfsBatchNo())){
			throw new RuntimeException("Ifs批次号不能为空!");
		}
		if(inventoryDetail.getInyQty()==null){
			throw new RuntimeException("盘点数量不能为空!");
		}
		if(StringUtils.isBlank(inventoryDetail.getLocNo())){
			throw new RuntimeException("库位号不能为空!");
		}
		InventoryDetail inventoryDetailBySelect = baseMapper.selectOne(Wrappers.<InventoryDetail>lambdaQuery()
				.eq(InventoryDetail::getInventoryMainId, inventoryDetail.getInventoryMainId())
				.eq(InventoryDetail::getPartNo, inventoryDetail.getPartNo())
				.eq(InventoryDetail::getSn, inventoryDetail.getSn())
				.eq(InventoryDetail::getIfsBatchNo, inventoryDetail.getIfsBatchNo())
				.eq(InventoryDetail::getLocNo, inventoryDetail.getLocNo()));

		return inventoryDetailBySelect;

	}


	public InventoryDetail getInventoryDetail(InventoryDetail inventoryDetail){
		Warehouse warehouse = baseMapper.getWarehouseName(inventoryDetail.getLocNo());
		Part part = partMapper.selectOne(Wrappers.<Part>lambdaQuery()
				.eq(Part::getPartNo, inventoryDetail.getPartNo()));
		inventoryDetail.setPlanningMethod(part.getPlanningMethod());
		inventoryDetail.setPartName(part.getPartName());
		inventoryDetail.setWarehouseId(warehouse.getId());
		inventoryDetail.setWarehouseName(warehouse.getWarehouseName());
		inventoryDetail.setStockQuantity(BigDecimal.ZERO);
		inventoryDetail.setInyDiffQty(inventoryDetail.getInyQty().negate());
		return inventoryDetail;

	}




	@Override
	public boolean updateBatch(List<InventoryDetail> inventoryDetails) {

		inventoryDetails.stream().forEach(inventoryDetail ->{
				inventoryDetail.setInyDiffQty(inventoryDetail.getStockQuantity()
						.subtract(BigDecimalUtils.getBigDecimalValue(inventoryDetail.getInyQty())));
	});
		updateBatchById(inventoryDetails);
		return true;
	}

	@Override
	public boolean noDiff(List<Long> ids) {
		List<InventoryDetail> inventoryDetails = baseMapper.selectBatchIds(ids);
		if(CollectionUtil.isNotEmpty(inventoryDetails)) {
			inventoryDetails.stream().forEach(inventoryDetail ->{
				if(inventoryDetail.getInyQty()==null){
					inventoryDetail.setInyQty(inventoryDetail.getStockQuantity());
				}
				inventoryDetail.setInyDiffQty(inventoryDetail.getStockQuantity().subtract(inventoryDetail.getInyQty()));
			});

			updateBatchById(inventoryDetails);
		}
		return true;
	}


	@Override
	public boolean cancelNoIny(List<Long> ids) {
		baseMapper.cancelNoIny(ids);
		return true;
	}

	@Override
	@Synchronized
	public boolean savePda(InventoryDetail inventoryDetail) {
		InventoryDetail inventoryDetailBySelect = judgeBlankAndRepeat(inventoryDetail);
		InventoryPda inventoryPda = new InventoryPda();
		inventoryPda.setPartNo(inventoryDetail.getPartNo());
		inventoryPda.setIfsBatchNo(inventoryDetail.getIfsBatchNo());
		inventoryPda.setSn(inventoryDetail.getSn());
		inventoryPda.setLocNo(inventoryDetail.getLocNo());
		inventoryPda.setInyQty(inventoryDetail.getInyQty());
		if(inventoryDetailBySelect==null){
			InventoryDetail detail = getInventoryDetail(inventoryDetail);
			detail.setCommitNum(1L);
			baseMapper.insert(detail);
			inventoryPda.setInventoryDetailId(detail.getId());
			inventoryPdaMapper.insert(inventoryPda);
		}else {
			inventoryPda.setInventoryDetailId(inventoryDetailBySelect.getId());
			inventoryPdaMapper.insert(inventoryPda);
			inventoryDetailBySelect.setInyQty(inventoryDetail.getInyQty().add(BigDecimalUtils.getBigDecimalValue(inventoryDetailBySelect.getInyQty())));
			if (inventoryDetailBySelect.getCommitNum() == null) {
				inventoryDetailBySelect.setCommitNum(1L);
			} else {
				inventoryDetailBySelect.setCommitNum(1L + inventoryDetailBySelect.getCommitNum());
			}
			inventoryDetailBySelect.setInyDiffQty(inventoryDetailBySelect.getStockQuantity().subtract(inventoryDetailBySelect.getInyQty()));
			baseMapper.updateById(inventoryDetailBySelect);
		}
		return true;
	}


	@Override
	@Synchronized
	public R checkSavePda(InventoryDetail inventoryDetail) {
		if(StringUtils.isBlank(inventoryDetail.getPartNo())){
			throw new RuntimeException("零件号不能为空!");
		}
		if(StringUtils.isBlank(inventoryDetail.getSn())){
			throw new RuntimeException("Sn号不能为空!");
		}
		if(StringUtils.isBlank(inventoryDetail.getIfsBatchNo())){
			throw new RuntimeException("Ifs批次号不能为空!");
		}
		if(StringUtils.isBlank(inventoryDetail.getLocNo())){
			throw new RuntimeException("库位号不能为空!");
		}
		//判断是否是盘点期间产出
		if(judgeIsInventoryTime(inventoryDetail.getSn())){
			throw new RuntimeException("盘点期间的产出冻结盘点操作");
		}

		InventoryDetail inventoryDetailBySelect = baseMapper.selectOne(Wrappers.<InventoryDetail>lambdaQuery()
				.eq(InventoryDetail::getInventoryMainId, inventoryDetail.getInventoryMainId())
				.eq(InventoryDetail::getPartNo, inventoryDetail.getPartNo())
				.eq(InventoryDetail::getSn, inventoryDetail.getSn())
				.eq(InventoryDetail::getIfsBatchNo, inventoryDetail.getIfsBatchNo())
				.eq(InventoryDetail::getLocNo, inventoryDetail.getLocNo()));
		if(inventoryDetailBySelect!=null){
			if(inventoryDetailBySelect.getCommitNum()==null){
				return R.ok(ValidateInventoryResultDTO.builder().success(Boolean.TRUE).build());
			}else{
				return R.ok(ValidateInventoryResultDTO.builder().success(Boolean.FALSE).message("该零件批次已扫描过，是否继续扫描").build());
			}
		}else{
			return R.ok(ValidateInventoryResultDTO.builder().success(Boolean.TRUE).build());
		}
	}



	/**
	 * 判断是否是盘点期间产出
	 */
	public boolean judgeIsInventoryTime(String sn){
		String res = remoteParamService.getByKey(CHECK_INVENTORY_STATE, SecurityConstants.FROM_IN).getData();
		if(null != res && res.equals("true")){
			List<LocalDateTime> createTimeList = baseMapper.getOutputCreateTime(sn);
			if(CollectionUtil.isNotEmpty(createTimeList)){
				String inventoryTime = remoteParamService.getByKey(INVENTORY_TIME, SecurityConstants.FROM_IN).getData();
				if(inventoryTime!=null) {
					DateTimeFormatter df = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
					LocalDateTime inventoryLocalDateTime = LocalDateTime.parse(inventoryTime, df);
					//产出表创建时间大于等于系统参数盘点更新时间则为 盘点产出
					if (createTimeList.get(0).isAfter(inventoryLocalDateTime) || createTimeList.get(0).equals(inventoryLocalDateTime)) {
						return true;
					}
				}
			}
		}
		return false;
	}



	/**
	 * 判断标签是否是盘点时打印
	 */
	@Override
	public List<String> judgeLabelMark(List<String> snList){
		String res = remoteParamService.getByKey(CHECK_INVENTORY_STATE, SecurityConstants.FROM_IN).getData();
		List<String> returnList = new ArrayList<>();
		if(null != res && res.equals("true")) {
			for (String sn : snList) {
				List<LocalDateTime> createTimeList = baseMapper.getOutputCreateTime(sn);
				if (CollectionUtil.isNotEmpty(createTimeList)) {
					String inventoryTime = remoteParamService.getByKey(INVENTORY_TIME, SecurityConstants.FROM_IN).getData();
					if (inventoryTime != null) {
						DateTimeFormatter df = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
						LocalDateTime inventoryLocalDateTime = LocalDateTime.parse(inventoryTime, df);
						//产出表创建时间大于等于系统参数盘点更新时间则为 盘点产出
						if (createTimeList.get(0).isAfter(inventoryLocalDateTime) || createTimeList.get(0).equals(inventoryLocalDateTime)) {
							returnList.add(sn);
						}
					}
				}
			}

		}
		return returnList;
	}
}