/*
 *    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.alibaba.fastjson.JSONObject;
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.ifs.api.feign.IfsFeignClient;
import com.chinaztt.mes.basic.entity.Part;
import com.chinaztt.mes.basic.mapper.LocationMapper;
import com.chinaztt.mes.basic.mapper.PartMapper;
import com.chinaztt.mes.warehouse.dto.IfsImportChangeWdrStdDTO;
import com.chinaztt.mes.warehouse.dto.MoveLibraryBoxDTO;
import com.chinaztt.mes.warehouse.dto.PackagingItemDTO;
import com.chinaztt.mes.warehouse.entity.Packaging;
import com.chinaztt.mes.warehouse.entity.PackagingItem;
import com.chinaztt.mes.warehouse.entity.ZxLabelBindRelation;
import com.chinaztt.mes.warehouse.mapper.PackagingItemMapper;
import com.chinaztt.mes.warehouse.mapper.PackagingMapper;
import com.chinaztt.mes.warehouse.mapper.ZxLabelBindRelationMapper;
import com.chinaztt.mes.warehouse.service.PackagingItemService;
import com.chinaztt.mes.warehouse.service.PackagingService;
import com.chinaztt.mes.warehouse.util.WareHouseUtils;
import com.chinaztt.ztt.common.core.util.R;
import com.google.gson.Gson;
import lombok.AllArgsConstructor;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.math.BigDecimal;
import java.util.*;
import java.util.stream.Collectors;

/**
 * 包装从表
 *
 * @author sunxl
 * @date 2021-06-03 15:19:30
 */
@Service
@AllArgsConstructor
@Transactional(rollbackFor = Exception.class)
public class PackagingItemServiceImpl extends ServiceImpl<PackagingItemMapper, PackagingItem> implements PackagingItemService {
	@Resource
    private PackagingMapper packagingMapper;
	@Resource
    private PartMapper partMapper;
	@Resource
    private WareHouseUtils wareHouseUtils;
	@Resource
	private PackagingService packagingService;
	@Resource
	private IfsFeignClient ifsFeignClient;
	@Resource
	private LocationMapper locationMapper;

	//@Qualifier("zxRelationMapper")
	@Resource
	private ZxLabelBindRelationMapper zxRelationMapper;

	@Override
	public IPage<List<PackagingItemDTO>> getPackagingItemPage(Page page, QueryWrapper<PackagingItemDTO> gen) {
		return baseMapper.getPackagingItemPage(page,gen);
	}

	@Override
	public Packaging removePackagingItemById(Long id) {
		PackagingItem packagingItem = baseMapper.selectById(id);

		if(wareHouseUtils.isPackConfirm(packagingItem.getPackagingId())){
			throw new RuntimeException("包装已提交->冻结该操作");
		}

		Part part = partMapper.selectById(packagingItem.getPartId());
		Packaging packaging = packagingMapper.selectById(packagingItem.getPackagingId());
		//修正包装主表的净重、包装数量、毛重、差异重量
		if (part!=null){
			//packaging.setNetWeight(packaging.getNetWeight().subtract(part.getWeight().multiply(packagingItem.getPackageQty())));
			//修改包装净重 = 包装净重 - 明细理论重量
			packaging.setNetWeight(packaging.getNetWeight().subtract(packagingItem.getTheoryWeight()));
			//修改包装毛重 = 包装净重 + 包装重量
			packaging.setGrossWeight(packaging.getNetWeight().add(packaging.getPackWeight()));
			if (packaging.getNetWeight().compareTo(BigDecimal.ZERO)!=0){
				if(packaging.getRealWeight() != null){
					packaging.setDifferenceWeight(packaging.getNetWeight().subtract(packaging.getRealWeight()));
				}else{
					packaging.setDifferenceWeight(packaging.getNetWeight());
				}
			}else{
				packaging.setDifferenceWeight(BigDecimal.ZERO);//差异重量置0
				packaging.setRealWeight(BigDecimal.ZERO);//实际重量置0
			}
		}
		//修改包装数量 = 包装数量 - 明细包装数量
		packaging.setNumber(packaging.getNumber().subtract(packagingItem.getPackageQty()));
		packagingMapper.updateById(packaging);
		baseMapper.deleteById(id);
		return packaging;
	}

	@Override
	public R updateInLocationNoBatch(List<PackagingItemDTO> packagingItemDTOList){
		List<Long> packIdList = new ArrayList<>();//包装主表记录行id
		if(CollectionUtil.isNotEmpty(packagingItemDTOList)){
			packIdList = packagingItemDTOList.stream().filter(o -> o.getPackagingId() != null).map(o -> o.getPackagingId()).collect(Collectors.toList());
			//包装主表id集合
			List<Long> distPackIdList = packIdList.stream().distinct().collect(Collectors.toList());
			if(distPackIdList.size() > 1){
				return R.failed("提交明细主表id不一致");
			}else if(distPackIdList.size() == 0){
				return R.failed("未获取到有效的包装主表id");
			}else{
				if(wareHouseUtils.isPackConfirm(distPackIdList.get(0))){
					return R.failed("包装已提交->冻结该操作");
				}
				for(PackagingItemDTO packagingItemDTO : packagingItemDTOList){
					//根据库位编号获取库位id
					List<Long> inLicationIdList = Collections.singletonList(baseMapper.getLocationIdByLocationNo(packagingItemDTO.getInLocationNo()));
					if(inLicationIdList.size() > 1 || inLicationIdList.size() == 0 || inLicationIdList.get(0) == null){
						return R.failed("根据库位编号=" + packagingItemDTO.getInLocationNo() + "->无法获取对应的库位id");
					}
					baseMapper.updateInLocationNoById(packagingItemDTO.getId(),inLicationIdList.get(0));
				}
				return R.ok(null,"操作成功");
			}
		}else{
			return R.failed("请求参数为空");
		}
	}

	@Override
	public R getEnableFinishProdList(String locType){
		return R.ok(baseMapper.getEnableFinishProdList(locType));
	}

	@Override
	public R updateInLocationByPda(String packagingNo,String inLocationNo){
		if(StringUtils.isBlank(packagingNo)||StringUtils.isBlank(inLocationNo)){
			throw new RuntimeException("包装编号和库位号不能为空");
		}
		List<PackagingItem> packagingItemList = baseMapper.getPackagingItemList(packagingNo);
		if (CollectionUtil.isEmpty(packagingItemList)) {
			throw new RuntimeException("没有包装明细");
		}
		if (wareHouseUtils.isPackConfirm(packagingItemList.get(0).getPackagingId())) {
			throw new RuntimeException("包装已提交->冻结该操作");
		}


		//更新至库位
		Long inLocationId = baseMapper.getLocationIdByLocationNo(inLocationNo);
		packagingItemList.stream().forEach(a-> a.setInLocationId(inLocationId));
		updateBatchById(packagingItemList);

		//移库
		R res = packagingService.packConfirm(packagingItemList.get(0).getPackagingId());

		//更新wdr
		doPdaPackaging(packagingItemList,packagingNo,inLocationNo);

		return res;

	}

	//ifs更新wdr接口
	private void doPdaPackaging(List<PackagingItem> packagingItemList, String packagingNo, String inLocationNo) {

		List<PackagingItemDTO> ifsPackagingList = baseMapper.getIfsPackagingList(packagingNo);
		//将list按照零件号进行分组，去除IFS启用批次管理为true的数据
		Map<String, List<PackagingItemDTO>> map = ifsPackagingList.stream().filter(x -> !x.getLotTrackingIfs()).collect(Collectors.groupingBy(PackagingItemDTO::getPartNo));
		List<PackagingItemDTO> ifsList = new ArrayList<>();
		for (Map.Entry<String, List<PackagingItemDTO>> entry : map.entrySet()){
			List<PackagingItemDTO> packagingItemDTOByGroupList = entry.getValue();
			//汇总相同零件号的移库数量
			BigDecimal packageQtySum = packagingItemDTOByGroupList.stream().filter(x -> x.getPackageQty() != null).map(PackagingItemDTO::getPackageQty).reduce(BigDecimal.ZERO, BigDecimal::add);
			PackagingItemDTO ifsDTO = new PackagingItemDTO();
			BeanUtils.copyProperties(packagingItemDTOByGroupList.get(0), ifsDTO);
			ifsDTO.setPackageQty(packageQtySum);
			ifsList.add(ifsDTO);
		}
		//筛选出IFS启用批次管理为true的数据
		List<PackagingItemDTO> lotTrackingIfsList = ifsPackagingList.stream().filter(PackagingItemDTO::getLotTrackingIfs).collect(Collectors.toList());
		ifsList.addAll(lotTrackingIfsList);

		IfsImportChangeWdrStdDTO ifsImportChangeWdrStdDTO = new IfsImportChangeWdrStdDTO();
		ifsImportChangeWdrStdDTO.setRECORD_ID(UUID.randomUUID().toString().replace("-", ""));
		List<IfsImportChangeWdrStdDTO.DataBean> dataBeanList = new ArrayList<>();//批量标识
		for(PackagingItemDTO packagingItemDTO:ifsList){
			IfsImportChangeWdrStdDTO.DataBean batchInfo = new IfsImportChangeWdrStdDTO.DataBean();
			batchInfo.setPART_NO(packagingItemDTO.getPartNo());//零件号
			batchInfo.setMOVE_QTY(packagingItemDTO.getPackageQty());//移库数量
			//判断是否启用批次管理
			//WDR号&批次号
			if(packagingItemDTO.getLotTrackingIfs() != null && packagingItemDTO.getLotTrackingIfs()){
				batchInfo.setWAIV_DEV_REJ_NO(packagingItemDTO.getOutBatchNo());
				batchInfo.setLOT_BATCH_NO(packagingItemDTO.getOutBatchNo());
			}else{
				batchInfo.setWAIV_DEV_REJ_NO("*");
				batchInfo.setLOT_BATCH_NO("*");
			}
			//版本号
			batchInfo.setENG_CHG_LEVEL(packagingItemDTO.getEngChgLevel());
			//库位号
			if(false){
				//移库与更新wdr操作调换了顺序，先移库，再更新wdr，此时更新wdr时传的库位由移库前的库位改成移库后的库位
				batchInfo.setLOCATION_NO(packagingItemDTO.getLocationNo());
			}
			batchInfo.setLOCATION_NO(inLocationNo);
			//至WDR号
			batchInfo.setTO_WAIV_DEV_REJ_NO(packagingNo);
			dataBeanList.add(batchInfo);
		}
		ifsImportChangeWdrStdDTO.setBATCH_INFO(dataBeanList);
		Gson gson = new Gson();
		String jsonstr = gson.toJson(ifsImportChangeWdrStdDTO);
		JSONObject jsonObject = JSONObject.parseObject(jsonstr);
		R res = ifsFeignClient.importChangeWdrStd(jsonObject, true);
		if(res.getCode() != 0){
			throw new RuntimeException("ifs更新wdr接口失败;erromsg:" + res.getMsg());
		}

		if(false){
			//更新至库位操作调到了移库操作之前执行
			Long inLocationId = baseMapper.getLocationIdByLocationNo(inLocationNo);
			packagingItemList.stream().forEach(a-> a.setInLocationId(inLocationId));
			updateBatchById(packagingItemList);
		}

	}

	@Override
	public R validatePackagingNoRepeat(String packagingCode, String pkgCode) {
		Integer count =
				zxRelationMapper.selectCount(Wrappers.<ZxLabelBindRelation>lambdaQuery().eq(ZxLabelBindRelation::getShopCode, "ZX")
						.and(wrapper -> wrapper.eq(ZxLabelBindRelation::getPackagingCode, packagingCode).or().eq(ZxLabelBindRelation::getPkgId, pkgCode)));
		if (count > 0) {
			return R.failed("请勿重复扫描入库");
		} else {
			return R.ok();
		}
	}

	@Override
	public R updateZxInLocationByPda(String packagingCode, String pkgCode, String inLocationNo) {
		if(StringUtils.isBlank(packagingCode)||StringUtils.isBlank(inLocationNo)){
			throw new RuntimeException("包装编号和库位号不能为空");
		}
		List<PackagingItem> packagingItemList = baseMapper.getPackagingItemList(packagingCode);
		if (CollectionUtil.isEmpty(packagingItemList)) {
			throw new RuntimeException("没有包装明细");
		}
		if (wareHouseUtils.isPackConfirm(packagingItemList.get(0).getPackagingId())) {
			throw new RuntimeException("包装已提交->冻结该操作");
		}

        R r = R.ok();
		try{
			//更新至库位
			Long inLocationId = baseMapper.getLocationIdByLocationNo(inLocationNo);
			packagingItemList.stream().forEach(a-> a.setInLocationId(inLocationId));
			updateBatchById(packagingItemList);

			//移库
			packagingService.packConfirm(packagingItemList.get(0).getPackagingId());

			//更新wdr
			doPdaPackaging(packagingItemList, packagingCode, inLocationNo);
		}catch(Exception e){
			r = R.failed(e.getMessage());
		}

        if (r.getCode() == 0) {
			//解析出所需数据
			String pkgId;
			String materialCode;//物料编码
			BigDecimal quality;//数量

			try{
				List<String> stringList = Arrays.asList(pkgCode.split("&"));
				if(stringList.size() < 3){
					//正常的按&切割后是8段，但只有前3段对我们是有用的
					throw new RuntimeException("PKG码格式错误");
				}else{
					pkgId = stringList.get(0);
					materialCode = stringList.get(1);
					quality = new BigDecimal(stringList.get(2));
				}
			}catch(Exception e){
				throw new RuntimeException("解析pkg码异常 -> " + e.getMessage());
			}

            ZxLabelBindRelation zxLabelBindRelation = new ZxLabelBindRelation();
            zxLabelBindRelation.setPackagingCode(packagingCode);
            zxLabelBindRelation.setPkgCode(pkgCode);
            zxLabelBindRelation.setShopCode("ZX");
            //追加补充部分信息，零件号、mes码、批次号、ce码无法补充
			zxLabelBindRelation.setPkgId(pkgId);
			zxLabelBindRelation.setMaterialCode(materialCode);
			zxLabelBindRelation.setQuantity(quality);
			zxRelationMapper.insert(zxLabelBindRelation);
			return R.ok();
        }else {
            return r;
        }
    }


}