/**
 * BladeX Commercial License Agreement
 * Copyright (c) 2018-2099, https://bladex.cn. All rights reserved.
 * <p>
 * Use of this software is governed by the Commercial License Agreement
 * obtained after purchasing a license from BladeX.
 * <p>
 * 1. This software is for development use only under a valid license
 * from BladeX.
 * <p>
 * 2. Redistribution of this software's source code to any third party
 * without a commercial license is strictly prohibited.
 * <p>
 * 3. Licensees may copyright their own code but cannot use segments
 * from this software for such purposes. Copyright of this software
 * remains with BladeX.
 * <p>
 * Using this software signifies agreement to this License, and the software
 * must not be used for illegal purposes.
 * <p>
 * THIS SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY. The author is
 * not liable for any claims arising from secondary or illegal development.
 * <p>
 * Author: Chill Zhuang (bladejava@qq.com)
 */
package org.springblade.mdm.program.service;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.io.IOUtils;
import org.springblade.core.mp.base.BizServiceImpl;
import org.springblade.core.mp.support.Condition;
import org.springblade.core.oss.OssTemplate;
import org.springblade.core.oss.model.BladeFile;
import org.springblade.mdm.basesetting.machine.MachineService;
import org.springblade.mdm.basesetting.machine.entity.Machine;
import org.springblade.mdm.flow.excution.StartDispatcher;
import org.springblade.mdm.flow.service.FlowCommonService;
import org.springblade.mdm.program.entity.NcNode;
import org.springblade.mdm.program.entity.NcProgram;
import org.springblade.mdm.program.entity.ProcessProgRef;
import org.springblade.mdm.program.entity.ProgramSeq;
import org.springblade.mdm.program.mapper.NcProgramMapper;
import org.springblade.mdm.program.mapper.ProcessProgRefMapper;
import org.springblade.mdm.program.mapper.ProgramSeqMapper;
import org.springblade.mdm.program.vo.NcNodeProgramQueryVO;
import org.springblade.mdm.program.vo.NcProgramUploadVO;
import org.springblade.mdm.program.vo.NcProgramVO;
import org.springblade.mdm.utils.FileContentUtil;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.multipart.MultipartFile;

import java.io.IOException;
import java.io.InputStream;
import java.nio.charset.StandardCharsets;
import java.text.DecimalFormat;
import java.util.ArrayList;
import java.util.List;

/**
 * 工作流服务实现类
 *
 * @author Chill
 */
@Slf4j
@Service
@AllArgsConstructor
public class ProcessProgRefService extends BizServiceImpl<ProcessProgRefMapper, ProcessProgRef> {
	private final FlowCommonService flowCommonService;
	/**
	 * 查询现有固化的程序，暂定条件：零组件号相同，且是同一机床组
	 * @param processInstanceId 流程实例id
	 * @param programIds 程序id
	 * @return
	 */
	@Transactional
	public void addRelations(String processInstanceId, List<Long> programIds) {
		if(programIds == null || programIds.isEmpty()) {
			return;
		}

		String processDefinationKey = flowCommonService.getDefinitionKey(processInstanceId);
		this.lambdaUpdate().eq(ProcessProgRef::getProcessInstanceId, processInstanceId).remove();
		List<ProcessProgRef> entities = new ArrayList<>();
		for (Long programId : programIds) {
			ProcessProgRef entity = new ProcessProgRef();
			entity.setProcessInstanceId(processInstanceId);
			entity.setNcProgramId(programId);
			entity.setProcessDefinitionKey(processDefinationKey);
			entities.add(entity);
		}
		this.saveBatch(entities);
	}

	/**
	 * 查询流程关联的程序
	 * @param processInstanceId
	 * @return
	 */
	public List<NcProgramVO> listByProcess(String processInstanceId) {
		return this.getBaseMapper().listByProcess(processInstanceId);
	}

	/**
	 *获取最后一调任务分派的数据，根据程序id
	 * @param ncProgramId 数控程序id
	 */
	public ProcessProgRef lastDispatchDataByNcProgramId(Long ncProgramId) {
		LambdaQueryWrapper<ProcessProgRef> query = Wrappers.lambdaQuery();

		query.eq(ProcessProgRef::getNcProgramId, ncProgramId).eq(ProcessProgRef::getProcessDefinitionKey, StartDispatcher.PROCESS_KEY).orderByDesc(ProcessProgRef::getCreateTime).last("LIMIT 1");;

		List<ProcessProgRef> list = this.list(query);
		return list.isEmpty() ? null : list.get(0);
	}
}