/*
 *    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.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
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.handler.StateMachineHandler;
import com.chinaztt.mes.common.numgen.NumberGenerator;
import com.chinaztt.mes.common.util.StateResult;
import com.chinaztt.mes.warehouse.dto.PrepareDetailDTO;
import com.chinaztt.mes.warehouse.dto.ReserveMainDTO;
import com.chinaztt.mes.warehouse.entity.PrepareDetail;
import com.chinaztt.mes.warehouse.entity.ReserveDetail;
import com.chinaztt.mes.warehouse.entity.ReserveMain;
import com.chinaztt.mes.warehouse.entity.Stock;
import com.chinaztt.mes.warehouse.mapper.PrepareDetailMapper;
import com.chinaztt.mes.warehouse.mapper.ReserveDetailMapper;
import com.chinaztt.mes.warehouse.mapper.ReserveMainMapper;
import com.chinaztt.mes.warehouse.mapper.StockMapper;
import com.chinaztt.mes.warehouse.service.ReserveMainService;
import com.chinaztt.mes.warehouse.state.ReserveStateMachineConfig;
import com.chinaztt.mes.warehouse.state.constant.ReserveEvents;
import com.chinaztt.mes.warehouse.state.constant.ReserveStates;
import com.chinaztt.mes.warehouse.util.StockUtils;
import lombok.AllArgsConstructor;
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 java.math.BigDecimal;
import java.time.LocalDateTime;
import java.util.List;

/**
 * 领料主表
 *
 * @author sunxl
 * @date 2020-10-13 13:30:50
 *
 */
@Service
@Transactional(rollbackFor = Exception.class)
@AllArgsConstructor
public class ReserveMainServiceImpl extends ServiceImpl<ReserveMainMapper, ReserveMain> implements ReserveMainService {
	private NumberGenerator<ReserveMain> numberGenerator;
	private ReserveDetailMapper reserveDetailMapper;
	private StockMapper stockMapper;
	private StockUtils stockUtils;
	private PrepareDetailMapper prepareDetailMapper;
	private StateMachineFactory<ReserveStates, ReserveEvents> reserveStateMachineFactory;
	private StateMachinePersister<ReserveStates, ReserveEvents, ReserveMain> persister;
	@Override

	public boolean fullSave(ReserveMain reserveMain) {
		reserveMain.setResNo(numberGenerator.generateNumberWithPrefix(ReserveMain.DIGIT, ReserveMain.PREFIX, ReserveMain::getResNo));
	    reserveMain.setResDate(LocalDateTime.now());
		baseMapper.insert(reserveMain);
		return false;
	}

	@Override
	public boolean fullDelete(Long id) {
		baseMapper.deleteById(id);
		reserveDetailMapper.delete(Wrappers.<ReserveDetail>query().lambda().eq(ReserveDetail::getWarehouseMainId,id));
		return true;
	}
	@Override
	public boolean updateReserve(List<Long> ids,String event) {
		List<ReserveDetail> reserveDetails = baseMapper.issueReserve(ids);
		for (int i = 0; i <reserveDetails.size(); i++) {
			if (reserveDetails.get(i) == null) {
				throw new RuntimeException("请重新选择申请单号，有申请单号没有配置零件");
			}
		}
		for(ReserveDetail reserveDetail : reserveDetails){
			reserveDetail.setStatus("已下发");
			reserveDetailMapper.updateById(reserveDetail);
		}
		changeResStatus(ids, event);
		return true;
	}
	@Override
	public IPage<List<ReserveMain>> getReserveMain(Page page, QueryWrapper<ReserveMain> gen, String type) {
		return baseMapper.getReserveMain(page, gen, type);
	}

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

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

	public void changeResStatus(List<Long> ids, String event) {
		for (Long id : ids) {
			ReserveMain reserveMain = baseMapper.selectById(id);
			Message<ReserveEvents> message = MessageBuilder.withPayload(ReserveEvents.valueOf(event)).setHeader("reserveMain", reserveMain).build();
			StateMachineHandler handler = new StateMachineHandler(reserveStateMachineFactory, persister, ReserveStateMachineConfig.MACHINE_ID, reserveMain);
			StateResult res = handler.sendEvent(message, reserveMain.getId());
			if (!res.isSuccess()) {
				throw new RuntimeException(res.getMsg());
			}
			}
		}
	}