package org.springblade.mdm.flow.excution.listeners;

import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springblade.core.tool.utils.DateUtil;
import org.springblade.mdm.flow.entity.MesSync;
import org.springblade.mdm.flow.entity.TaskDispatch;
import org.springblade.mdm.flow.excution.events.CureFinishedEvent;
import org.springblade.mdm.flow.service.MesSyncService;
import org.springblade.mdm.flow.service.TaskDispatchService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Component;

import java.util.Date;

/**
 * 固化流程执行完成后，需要处理的事件：入库mes同步表
 */
@Slf4j
@Component
public class CuredEventListener {
	@Autowired
	private TaskDispatchService taskDispatchService;
	@Autowired
	private MesSyncService mesSyncService;

	@EventListener(value = CureFinishedEvent.class)
	public void hello(CureFinishedEvent event) {
		TaskDispatch dispatch = taskDispatchService.getByProgramNo(event.getProgramNo());
		if (dispatch == null) {
			log.info("根据程序编号:{}找不到任务分派记录", event.getProgramNo());
			return;
		}
		if (StringUtils.isBlank(dispatch.getOperationId())) {
			log.info("任务dispatch.id:{}对应的operation_id 为空，不记入同步mes表", dispatch.getId());
			return;
		}

		MesSync sync = new MesSync();
		sync.setStatus(MesSync.STATUS_CREATED);
		sync.setOperationId(dispatch.getOperationId());
		sync.setProgramNo(dispatch.getProgramNo());
		sync.setTryTimes(0);
		Date now = new Date();
		sync.setCuredTime(now);
		sync.setCreateTime(now);
		sync.setUpdateTime(now);

		mesSyncService.saveAndSync(sync);
	}

}