package org.sxkj.job.processor.odm; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import org.sxkj.odm.feign.IOdmTaskInfoClient; import tech.powerjob.worker.core.processor.ProcessResult; import tech.powerjob.worker.core.processor.TaskContext; import tech.powerjob.worker.core.processor.sdk.BasicProcessor; /** * odm 任务状态 */ @Slf4j @Component public class CreateWebOdmTaskProcessor implements BasicProcessor { @Autowired private IOdmTaskInfoClient odmTaskInfoClient; /** * 执行webodm任务 * @param taskContext * @return */ @Override public ProcessResult process(TaskContext taskContext){ log.info("任务信息:{}",taskContext); boolean flag = odmTaskInfoClient.createWebOdmTask(); return new ProcessResult(true,"本次在webodm创建任务:" + flag); } }