package org.springblade.mdm.machinefile.listeners;

import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springblade.core.tool.utils.BeanUtil;
import org.springblade.core.tool.utils.Func;
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.springblade.mdm.machinefile.entity.MachineAcceptedFile;
import org.springblade.mdm.machinefile.entity.MachineFile;
import org.springblade.mdm.machinefile.events.ExportedToInnerEvent;
import org.springblade.mdm.machinefile.service.MachineAcceptedFileService;
import org.springblade.mdm.machinefile.service.MachineFileService;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Component;

import java.util.Date;
import java.util.List;
import java.util.Optional;

/**
 * 视情况将已经导出的现场编程文件，保存到PROGRAM文件夹
 */
@Slf4j
@Component
public class ExportToInnerListener {
	@Autowired
	private MachineFileService machineFileService;
	@Autowired
	private MachineAcceptedFileService machineAcceptedService;

	@EventListener(value = ExportedToInnerEvent.class)
	public void hello(ExportedToInnerEvent event) {
		//已经导出到涉密网事件，检查是否有导出的现场编程数据。如果有则加入program文件夹
		if(Func.isEmpty(event.getAcceptedFiles())){
			return;
		}
		List<MachineFile> onMachineFiles = machineAcceptedService.exportedProgramOnMachineFiles(event.getAcceptedFiles());

		//保存入program
		saveOrUpdateToProgramFolder(onMachineFiles,event.getAcceptedFiles());
	}

	/**
	 * 更新或爆粗文件到program文件夹
	 * @param onMachineFiles 现场编程文件列表
	 * @param acceptedFiles 导出涉密网的文件列表
	 */
	void saveOrUpdateToProgramFolder(List<MachineFile> onMachineFiles,List<MachineAcceptedFile> acceptedFiles){

		for(MachineFile machineFile : onMachineFiles){
			Optional<MachineAcceptedFile> accFileOpt = acceptedFiles.stream().filter(a -> a.getMachineFileId().equals(machineFile.getId())).findFirst();
			if(accFileOpt.isEmpty()){
				continue;
			}

			MachineFile existsFile = machineFileService.getByNameAndMachineInDir(machineFile.getName(),machineFile.getMachineCode(),MachineFile.DIR_TYPE_PROGRAM);
			if(existsFile != null){
				BeanUtils.copyProperties(machineFile,existsFile);

				existsFile.setDirType(MachineFile.DIR_TYPE_PROGRAM);
				existsFile.setOssName(accFileOpt.get().getOssName());
				existsFile.setStatus(MachineFile.STATUS_NORMAL);
				existsFile.setOssName(existsFile.getOssName());
				machineFileService.updateById(existsFile);
			}else{
				MachineFile newProgFile = new MachineFile();
				BeanUtils.copyProperties(machineFile,newProgFile);
				newProgFile.setDirType(MachineFile.DIR_TYPE_PROGRAM);
				newProgFile.setStatus(MachineFile.STATUS_NORMAL);
				newProgFile.setOssName(accFileOpt.get().getOssName());
				newProgFile.setId(null);
				machineFileService.save(newProgFile);
			}
		}


	}

}