Class MainTask

src/main/java/com/jiaruiblog/task/thread/MainTask.java:25–149

@Author Jarrett Luo @Date 2022/10/20 17:59 @Version 1.0

 * @Version 1.0
 */
@Slf4j
public class MainTask implements RunnableTask {

    private final TaskExecutor taskExecutor;

    private final TaskData taskData = new TaskData();

    /**
     * @Author luojiarui
     * @Description // 初始化任务，指定一个
     * @Date 15:43 2022/11/13
     * @Param [fileDocument]
     **/
    public MainTask(FileDocument fileDocument) {
        taskData.setFileDocument(fileDocument);
        taskData.setThumbFilePath("");
        taskData.setThumbFilePath("");
        String fileSuffix = fileDocument.getSuffix();
        DocType docType = DocType.getDocType(fileSuffix);
        taskData.setDocType(docType);
        this.taskExecutor = TaskExecutorFactory.getTaskExecutor(docType);
    }

    /**
     * @Author luojiarui
     * @Description 成功以后更新文件
     * @Date 18:17 2022/11/13
     * @Param []
     **/
    @Override
    public void success() {
        taskData.getFileDocument().setDocState(DocStateEnum.SUCCESS);
        updateTaskStatus();

        // 更新文档的数据
        IFileService fileService = SpringApplicationContext.getBean(IFileService.class);
        fileService.updateFile(taskData.getFileDocument());
    }

    @Override
    public void failed(Throwable throwable) {
        log.error("解析文件报错啦", throwable);
        String errorMsg = throwable.getMessage();
        taskData.getFileDocument().setDocState(DocStateEnum.FAIL);
        taskData.getFileDocument().setErrorMsg(errorMsg +" " + throwable.getCause());
        updateTaskStatus();
    }

    @Override
    public void run() {
        FileDocument fileDocument = taskData.getFileDocument();
        if (null == taskExecutor || fileDocument == null) {
            log.error("执行文件{}报错",fileDocument);
            throw new TaskRunException("当前执行器初始化失败！");
        }
        if (StringUtils.hasText(fileDocument.getThumbId()) || StringUtils.hasText(fileDocument.getTextFileId())) {
            removeExistGridFs();
        }