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; @Slf4j @Component public class OdmGenerateGridProcessor implements BasicProcessor { @Autowired private IOdmTaskInfoClient odmTaskInfoClient; @Override public ProcessResult process(TaskContext taskContext) throws Exception { log.info("生成网格任务开始:{}", taskContext); odmTaskInfoClient.generateGridTask(); log.info("生成网格任务结束"); return new ProcessResult(true, "生成网格任务结束"); } }