package org.springblade.mdm.machinefile.controller;

import com.baomidou.mybatisplus.core.metadata.IPage;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.extern.slf4j.Slf4j;
import org.springblade.core.tool.api.R;
import org.springblade.mdm.basesetting.machine.service.MachineService;
import org.springblade.mdm.basesetting.machine.entity.Machine;
import org.springblade.mdm.basesetting.producedivision.entity.MdmDept;
import org.springblade.mdm.basesetting.producedivision.service.MdmDeptService;
import org.springblade.mdm.machinefile.entity.MachineFile;
import org.springblade.mdm.machinefile.service.MachineAcceptedFileService;
import org.springblade.mdm.machinefile.service.MachineFileService;
import org.springblade.mdm.machinefile.vo.MachineBackFileQueryVO;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import java.util.ArrayList;
import java.util.List;

@Slf4j
@RestController
@RequestMapping("/machinefile/collect")
@Tag(name = "机床回传文件", description = "机床回传文件")
public class MachineCollectFileController {

	@Autowired
	private MachineAcceptedFileService service;
	@Autowired
	private MachineFileService machineFileService;
	@Autowired
	private MachineService machineService;
	@Autowired
	private MdmDeptService mdmDeptService;
	/**
	 * 接收
	 */
	@Operation(summary = "接收", description = "接收文件")
	@PostMapping("/temp-accept")
	public R<Void> accept(@RequestParam String ids) {
		try {
			service.accept(ids);
			return R.success();
		}catch(Exception e) {
			log.error("接受选中文件异常",e);
			return R.fail(e.getMessage());
		}
	}

	@Operation(summary = "批量接收", description = "接收所有文件")
	@PostMapping("/temp-accept-all")
	public R<Void> acceptAll() {
		try {
			service.acceptAll();
			return R.success();
		}catch(Exception e) {
			log.error("接受全部文件异常",e);
			return R.fail(e.getMessage());
		}
	}

	/**
	 *拒绝，就是删除
	 */
	@Operation(summary = "拒绝", description = "拒绝")
	@PostMapping("/temp-reject")
	public R<Void> reject(@RequestParam String ids) {
		try {
			service.reject(ids);
		} catch (Exception e) {
			log.error("拒绝异常",e);
			return R.fail(e.getMessage());
		}
		return R.status(true);
	}

	/**
	 * 分页
	 */
	@Operation(summary = "机床文件TEMP目录分页查询", description = "击穿文件分页查询，查询目录中的文件，还不算时机床回传文件")
	@GetMapping("/file-page-for-acceept")
	public R<IPage<MachineFile>> filePageForAccept(MachineBackFileQueryVO query) {
		if("workshop".equals(query.getNodeType()) || "seg".equals(query.getNodeType())) {
			//节点为车间、工段
			MdmDept dept = mdmDeptService.getById(query.getNodeId());

			String idStr = dept.getAncestors()+","+dept.getId();
			List<MdmDept> depts = mdmDeptService.lambdaQuery().likeRight(MdmDept::getParentId, query.getNodeId()).list();
			List<Long> deptIds = new ArrayList<>(depts.stream().map(MdmDept::getId).toList());
			deptIds.add(dept.getId());
			//+本车间
			//Func.toStrList(",",idStr)
			query.setDeptIds(deptIds);
		}else if("machine".equals(query.getNodeType())){
			Machine machine = machineService.getById(query.getNodeId());
			query.setMachineCode(machine.getCode());
		}else if("dir".equals(query.getNodeType())){
			query.setMachineCode(query.getMachineCode());
		}
		IPage<MachineFile> pages = machineFileService.filePageForAccept(query);
		return R.data(pages);
	}
	/**
	 * 分页
	 */
	/*
	@Operation(summary = "导出Excel", description = "导出Excel")
	@GetMapping("/export-excel")
	public void exportExcel(MachineBackFileQueryVO query, HttpServletResponse response) {
		query.setCurrent(1);
		query.setSize(Integer.MAX_VALUE);

		//IPage<MachineBackFileVO> pages = service.pageQuery(query);
		IPage<MachineFile> pages = machineFileService.filePageForAccept(query);
		List<MachineBackFileExcelVO> list = new ArrayList<>();
		pages.getRecords().forEach(m ->{
			MachineBackFileExcelVO excelVO = new MachineBackFileExcelVO();
			BeanUtils.copyProperties(m, excelVO);
			list.add(excelVO);
		});
		ExcelUtil.export(response, "机床回传文件" + DateUtil.time(), "机床回传文件表", list, MachineBackFileExcelVO.class);
	}*/
}