package com.dk.mdm.service.ivt.inbound;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.dk.common.exception.BaseBusinessException;
import com.dk.common.infrastructure.constant.Constant;
import com.dk.common.infrastructure.enums.ErrorCodeEnum;
import com.dk.common.mapper.BaseMapper;
import com.dk.common.response.ResponseResultUtil;
import com.dk.common.response.ResponseResultVO;
import com.dk.common.service.BaseService;
import com.dk.mdm.infrastructure.convert.ivt.InboundConvert;
import com.dk.mdm.infrastructure.convert.ivt.InboundItemConvert;
import com.dk.mdm.mapper.ivt.InboundItemMapper;
import com.dk.mdm.mapper.ivt.InboundMapper;
import com.dk.mdm.model.pojo.ivt.Inbound;
import com.dk.mdm.model.pojo.ivt.InboundItem;
import com.dk.mdm.model.vo.ivt.InboundItemVO;
import com.dk.mdm.model.vo.ivt.InboundVO;
import com.dk.mdm.service.common.CommonService;
import com.dk.mdm.service.ivt.inventory.InventoryService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.math.BigDecimal;
import java.util.HashMap;
import java.util.List;
import java.util.Map;


/**
 * @desc   : 盘盈入库业务层
 * @date   : 2024/3/7 14:11
 * @author : 寇珊珊
 */
@Service
public class InboundCheckService extends BaseService<Inbound> {

	@Override
	public BaseMapper<Inbound> getRepository() {
		return inboundMapper;
	}

	@Autowired
	private InboundMapper inboundMapper;

	@Autowired
	private InboundConvert inboundConvert;

	@Autowired
	private InboundItemMapper inboundItemMapper;

	@Autowired
	private InboundItemConvert inboundItemConvert;


	@Autowired
	private CommonService commonService;

	@Autowired
	private InventoryService inventoryService;


	/**
	 * @desc : 盘盈入库新建
	 * @date : 2024/3/7 14:13
	 * 入库中数量/金额  已入库数量/金额  由调用方传入
	 * @author : 寇珊珊
	 */
	@Transactional(rollbackFor = {Exception.class})
	public ResponseResultVO<?> checkInboundInsert(Map<String, Object> map) {
		//region map转json
		JSONObject total = new JSONObject();
		JSONArray detail = new JSONArray();
		//总单
		if (map.get("total") != null) {
			total = (JSONObject) JSON.toJSON(map.get("total"));
		}
		//明细
		if (map.get("total") != null) {
			detail = (JSONArray) JSON.toJSON(map.get("detail"));
		}
		InboundVO inboundVO = new InboundVO();
		inboundVO = total.toJavaObject(InboundVO.class);
		List<InboundItemVO> inboundItemVOList = detail.toJavaList(InboundItemVO.class);
		inboundVO.setItemList(inboundItemVOList);
		//endregion

		//region  总单
		//获取 id/单号
		Map<String, Object> codeMap = commonService.getUniqueNoteCode(Constant.docNameConstant.INVENTORYPROFITINBOUND.getName(), false);
		inboundVO.setIntoId(codeMap.get("outId").toString()).
				setIntoNo(codeMap.get("outNote").toString());
		//入库类型
		inboundVO.setIntoType(Constant.IntoType.PROFIT.getName());
		//已入库
		inboundVO.setIntoStatus(Constant.IntoStatus.YIRUKU.getName());
		//入库状态等于已入库 更新合计入库数量/金额 = 入库中数量/入库中金额
		inboundVO.setIntoQty(inboundVO.getIntoingQty())
				.setIntoAmt(inboundVO.getIntoingAmt())
				.setIntoingQty(BigDecimal.ZERO)
				.setIntoingAmt(BigDecimal.ZERO)
		;
		//实体转换
		Inbound inbound = inboundConvert.convertToPo(inboundVO);
		inboundMapper.insert(inbound);
		//endregion


		//region 明细
		//校验明细
		if (inboundVO.getItemList().size() == 0) {
			throw new BaseBusinessException(ErrorCodeEnum.INBOUND_ITEM_NOT_EXIST.getCode(),
					ErrorCodeEnum.INBOUND_ITEM_NOT_EXIST.getMessage());
		}
		for (InboundItemVO inboundItemVO : inboundVO.getItemList()) {
			//region 将库存需要的参数赋值
			inboundItemVO.setInventoryType(Constant.InventoryType.INBOUND.getName());
			inboundItemVO.setInventoryDocCode(Constant.InventoryDocCode.INVENTORY_PROFIT.getValue());
			//endregion


			//总单id
			inboundItemVO.setIntoId(inboundVO.getIntoId());
			//入库类型
			inboundItemVO.setIntoType(inboundVO.getIntoType());
			//入库状态等于已入库 更新合计入库数量/金额 = 入库中数量/入库中金额
			inboundItemVO
					.setIntoQty(inboundItemVO.getIntoingQty())
					.setIntoAmt(inboundItemVO.getIntoingAmt())
					.setIntoingQty(BigDecimal.ZERO)
					.setIntoingAmt(BigDecimal.ZERO)
					.setCostPrice(inboundItemVO.getPriceInto())
					.setCostAmt(inboundItemVO.getIntoQty().multiply(inboundItemVO.getPriceInto()).setScale(2, BigDecimal.ROUND_HALF_UP))
			;
			//入库状态
			inboundItemVO.setIntoStatus(inboundVO.getIntoStatus());
			//实体转换
			InboundItem inboundItem = inboundItemConvert.convertToPo(inboundItemVO);
			inboundItemMapper.insert(inboundItem);
			//endregion

		}
		//endregion

		//region 修改库存
//		Map<String, Object> invMap = new HashMap<>();
//		invMap.put("intoDetail", inboundVO.getItemList());
//		inventoryService.updateInventoryInformation(invMap);
		//endregion

		return ResponseResultUtil.success(inboundVO);
	}

}