|
@@ -6,6 +6,7 @@ import lombok.extern.slf4j.Slf4j;
|
|
|
import org.springframework.stereotype.Component;
|
|
|
import tech.powerjob.work.entity.DredgingImportRule;
|
|
|
import tech.powerjob.work.service.DredgingService;
|
|
|
+import tech.powerjob.work.util.ReturnMsg;
|
|
|
import tech.powerjob.worker.core.processor.ProcessResult;
|
|
|
import tech.powerjob.worker.core.processor.TaskContext;
|
|
|
import tech.powerjob.worker.core.processor.sdk.BasicProcessor;
|
|
@@ -27,10 +28,10 @@ public class DredgingSchedule implements BasicProcessor {
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
log.error("{}疏浚数据导入失败", e.getMessage());
|
|
|
- return new ProcessResult(false);
|
|
|
+ return ReturnMsg.returnMsg(false);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
- return new ProcessResult(true);
|
|
|
+ return ReturnMsg.returnMsg(true);
|
|
|
}
|
|
|
}
|