package com.qianwen.smartman.modules.dnc.controller;
|
|
import cn.hutool.core.io.IoUtil;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import io.swagger.annotations.ApiParam;
|
import java.io.IOException;
|
import java.io.InputStream;
|
import java.util.List;
|
import javax.servlet.http.HttpServletResponse;
|
import javax.validation.Valid;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import com.qianwen.smartman.common.constant.DncConstant;
|
import com.qianwen.core.mp.support.Query;
|
import com.qianwen.core.scanner.modular.annotation.GetResource;
|
import com.qianwen.core.scanner.modular.annotation.PostResource;
|
import com.qianwen.core.scanner.modular.stereotype.ApiResource;
|
import com.qianwen.core.secure.annotation.PreAuth;
|
import com.qianwen.core.tool.api.R;
|
import com.qianwen.smartman.modules.dnc.dto.serial.SerialInfoDTO;
|
import com.qianwen.smartman.modules.dnc.dto.serial.SerialSetting;
|
import com.qianwen.smartman.modules.dnc.service.ITransferDirectoryFileService;
|
import com.qianwen.smartman.modules.dnc.vo.DncReadFileVO;
|
import com.qianwen.smartman.modules.dnc.vo.FileHistoryVO;
|
import com.qianwen.smartman.modules.dnc.vo.FileVersionSwitchVO;
|
import com.qianwen.smartman.modules.dnc.vo.MachineToolBatchWriteFileVO;
|
import com.qianwen.smartman.modules.dnc.vo.ReceiveScheduleVO;
|
import com.qianwen.smartman.modules.dnc.vo.SendScheduleVO;
|
import com.qianwen.smartman.modules.dnc.vo.SerialSendVO;
|
import com.qianwen.smartman.modules.dnc.vo.TransferDirectoryFilePageVO;
|
import com.qianwen.smartman.modules.dnc.vo.TransferDirectoryFileVo;
|
import com.qianwen.smartman.modules.dnc.vo.UploadFileOssVO;
|
import com.qianwen.smartman.modules.dnc.vo.WorkstationDetailVO;
|
import com.qianwen.smartman.modules.dnc.vo.WorkstationDirectoryFileVO;
|
import com.qianwen.smartman.modules.dnc.vo.WorkstationFileSearchVO;
|
import com.qianwen.smartman.modules.dnc.vo.WorkstationFileVO;
|
import com.qianwen.smartman.modules.dnc.vo.WorkstationFromDocumentsVO;
|
import org.springframework.web.bind.annotation.PathVariable;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.RequestParam;
|
import org.springframework.web.bind.annotation.RestController;
|
|
@ApiResource({"blade-dnc/transfer-directory"})
|
@Api(value = "传输目录文件增删接口", tags = {"传输目录文件增删controller"})
|
@RestController
|
/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/dnc/controller/TransferDirectoryFileController.class */
|
public class TransferDirectoryFileController {
|
private static final Logger log = LoggerFactory.getLogger(TransferDirectoryFileController.class);
|
private final ITransferDirectoryFileService transferDirectoryFileService;
|
|
public TransferDirectoryFileController(final ITransferDirectoryFileService transferDirectoryFileService) {
|
this.transferDirectoryFileService = transferDirectoryFileService;
|
}
|
|
@PostResource({"/file"})
|
@ApiOperation(value = "工位目录文件保存", notes = "工位目录文件保存")
|
public R<List<WorkstationDirectoryFileVO>> save(@RequestBody WorkstationFileVO workstationFileVo) {
|
return R.data(this.transferDirectoryFileService.saveBatchFile(workstationFileVo));
|
}
|
|
@PreAuth
|
@PostResource({"/duplicate-file"})
|
@ApiOperation(value = "验证文件是否重复", notes = "验证文件是否重复 true 是 false 否")
|
public R<Boolean> existDuplicateFile(@RequestBody WorkstationFileVO workstationFileVo) {
|
return R.data(this.transferDirectoryFileService.existDuplicateFileBatch(workstationFileVo));
|
}
|
|
@PostResource({"/fileList"})
|
@ApiOperation(value = "获取工位目录下的文件列表", notes = DncConstant.WORK_STATION_FILE)
|
public R<List<TransferDirectoryFileVo>> getWorkstationFile(@RequestBody WorkstationDetailVO workstationDetailVO) {
|
return R.data(this.transferDirectoryFileService.fileList(workstationDetailVO));
|
}
|
|
@PreAuth
|
@GetResource({"/delete-file/{workstationFileId}"})
|
@ApiOperation(value = "删除工位文件", notes = "工位文件id")
|
public R<Boolean> deleteWorkstationFile(@PathVariable @ApiParam("工位id") String workstationFileId) {
|
return R.data(this.transferDirectoryFileService.deleteWorkstationDirectoryFile(workstationFileId));
|
}
|
|
@PreAuth
|
@PostResource({"/workstation-from-documents"})
|
@ApiOperation(value = "工位文件批量上传到我的文档", notes = "上传文件:fileType 加工程序 1 工艺文件 2")
|
public R<List<UploadFileOssVO>> workstationFromDocuments(@RequestBody WorkstationFromDocumentsVO workstationFromDocumentsVO) {
|
List<UploadFileOssVO> uploadFileOssList = this.transferDirectoryFileService.workstationFromFile(workstationFromDocumentsVO.getFileType(), workstationFromDocumentsVO.getList());
|
return R.data(uploadFileOssList);
|
}
|
|
@PreAuth
|
@GetResource({"/{fileId}/fileHistoryList"})
|
@ApiOperation(value = "工位文件版本历史列表", notes = "文件id")
|
public R<List<FileHistoryVO>> getFileHistory(@PathVariable @ApiParam("工位文件id") String fileId) {
|
return R.data(this.transferDirectoryFileService.getFileCoverHistory(fileId));
|
}
|
|
@PreAuth
|
@PostResource({"/switch-file"})
|
@ApiOperation(value = "切换文件版本", notes = "切换当前文件版本")
|
public R<Boolean> switchFile(@RequestBody FileVersionSwitchVO fileVersionSwitchVO) {
|
return R.data(this.transferDirectoryFileService.fileVersionSwitching(fileVersionSwitchVO));
|
}
|
|
@PreAuth
|
@PostResource({"/page"})
|
@ApiOperation(value = "工位文件（分页）", notes = "根据工位workstationId获取文件列表")
|
public IPage<TransferDirectoryFilePageVO> filePages(@RequestBody WorkstationFileSearchVO searchDTO, Query query) {
|
return this.transferDirectoryFileService.getFilePages(searchDTO, query);
|
}
|
|
@PostResource({"/online-write-file"})
|
@ApiOperation(value = "文件在线写入", notes = "文件写入")
|
public R<MachineToolBatchWriteFileVO> onlineWrite(@Valid @RequestBody MachineToolBatchWriteFileVO writeFileVO) {
|
return R.data(this.transferDirectoryFileService.batchOnlineWriteFile(writeFileVO));
|
}
|
|
@PostResource({"/online-read-file"})
|
@ApiOperation(value = "在线读文件", notes = "读取机床文件")
|
public void onlineRead(@Valid @RequestBody DncReadFileVO dncReadFileVO, HttpServletResponse response) {
|
try {
|
InputStream objectStream = this.transferDirectoryFileService.readDncOnlineFile(dncReadFileVO);
|
response.setContentType("application/octet-stream; charset=UTF-8");
|
response.addHeader("Expires", "0");
|
response.addHeader("Pragma", "no-cache");
|
response.addHeader("Cache-Control", "no-cache, no-store, must-revalidate");
|
IoUtil.copy(objectStream, response.getOutputStream());
|
if (objectStream != null) {
|
if (0 != 0) {
|
objectStream.close();
|
} else {
|
objectStream.close();
|
}
|
}
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
|
@GetResource({"/get-online-read-file"})
|
@ApiOperation(value = "hmi在线读文件", notes = "hmi读取机床文件")
|
public void getOnlineRead(@RequestParam("workstationId") String workstationId, @RequestParam("fileName") String fileName, HttpServletResponse response) {
|
DncReadFileVO dncReadFileVO = new DncReadFileVO();
|
dncReadFileVO.setWorkstationId(workstationId);
|
dncReadFileVO.setFileName(fileName);
|
log.error("------------------------------workstationId: {}", workstationId);
|
log.error("------------------------------fileName: {}", fileName);
|
try {
|
InputStream objectStream = this.transferDirectoryFileService.readDncOnlineFile(dncReadFileVO);
|
response.setContentType("application/octet-stream; charset=UTF-8");
|
response.addHeader("Expires", "0");
|
response.addHeader("Pragma", "no-cache");
|
response.addHeader("Cache-Control", "no-cache, no-store, must-revalidate");
|
IoUtil.copy(objectStream, response.getOutputStream());
|
if (objectStream != null) {
|
if (0 != 0) {
|
objectStream.close();
|
} else {
|
objectStream.close();
|
}
|
}
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
|
@PostResource({"/online-del-file"})
|
@ApiOperation(value = "删除机床文件", notes = "删除文件")
|
public R<String> onlineDel(@Valid @RequestBody DncReadFileVO dncReadFileVO) {
|
return R.data(this.transferDirectoryFileService.delOnlineFile(dncReadFileVO));
|
}
|
|
@PostResource({"/online-file-list"})
|
@ApiOperation(value = "机床文件列表", notes = "文件列表")
|
public R<List<TransferDirectoryFileVo>> getOnlineFileList(@Valid @RequestBody DncReadFileVO dncReadFileVO) {
|
return R.data(this.transferDirectoryFileService.getOnlineFileList(dncReadFileVO));
|
}
|
|
@ApiOperationSupport(order = 14)
|
@GetResource({"/serial-list"})
|
@ApiOperation("获取串口列表")
|
public R<List<SerialInfoDTO>> allSerialList() {
|
return R.data(this.transferDirectoryFileService.allSerialList());
|
}
|
|
@ApiOperationSupport(order = 15)
|
@PostResource({"/download-send"})
|
@ApiOperation("在线下载文件 串口发送")
|
public R<Integer> serialDownloadSend(@RequestBody SerialSendVO vo) {
|
return R.data(this.transferDirectoryFileService.serialDownloadSend(vo));
|
}
|
|
@ApiOperationSupport(order = 16)
|
@GetResource({"/send-schedule"})
|
@ApiOperation("获取串口发送进度")
|
public R<SendScheduleVO> sendSchedule() {
|
return R.data(this.transferDirectoryFileService.sendSchedule());
|
}
|
|
@ApiOperationSupport(order = 17)
|
@PostResource({"/serial-receive"})
|
@ApiOperation("串口接收")
|
public R<Boolean> serialReceive(@RequestBody SerialSetting serialSetting) {
|
return R.data(Boolean.valueOf(this.transferDirectoryFileService.serialReceive(serialSetting)));
|
}
|
|
@ApiOperationSupport(order = 18)
|
@GetResource({"/receive-schedule"})
|
@ApiOperation("接收进度")
|
public R<ReceiveScheduleVO> receiveSchedule(@RequestParam("encodingType") String encodingType) {
|
return R.data(this.transferDirectoryFileService.receiveSchedule(encodingType));
|
}
|
|
@ApiOperationSupport(order = 19)
|
@GetResource({"/transport-cancel"})
|
@ApiOperation("关闭串口传输")
|
public R<Boolean> transportCancel() {
|
return R.data(Boolean.valueOf(this.transferDirectoryFileService.transportCancel()));
|
}
|
|
@ApiOperationSupport(order = 20)
|
@PostResource({"/serial-save-file"})
|
@ApiOperation("获取文件内容保存之后 生成传输文件信息")
|
public R<List<WorkstationDirectoryFileVO>> serialSaveFile(@RequestBody WorkstationDirectoryFileVO vo) {
|
return R.data(this.transferDirectoryFileService.serialSaveFile(vo));
|
}
|
}
|
