From 622183e2763b98cd8778e1662820950898bdc9dc Mon Sep 17 00:00:00 2001 From: Tim Chamberlain Date: Thu, 27 Oct 2022 13:17:38 -0500 Subject: [PATCH] sprint-14: moved getting of timestamps into their own methods that can be overridden by subclasses --- .../basepull/ExtractViaBasepullQueryStep.java | 24 +++++++++++++++++-- 1 file changed, 22 insertions(+), 2 deletions(-) diff --git a/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/processes/implementations/basepull/ExtractViaBasepullQueryStep.java b/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/processes/implementations/basepull/ExtractViaBasepullQueryStep.java index 9e2654be..806483af 100644 --- a/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/processes/implementations/basepull/ExtractViaBasepullQueryStep.java +++ b/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/processes/implementations/basepull/ExtractViaBasepullQueryStep.java @@ -68,15 +68,35 @@ public class ExtractViaBasepullQueryStep extends ExtractViaQueryStep queryFilter.addCriteria(new QFilterCriteria() .withFieldName(runBackendStepInput.getValueString(RunProcessAction.BASEPULL_TIMESTAMP_FIELD)) .withOperator(QCriteriaOperator.GREATER_THAN) - .withValues(List.of(runBackendStepInput.getBasepullLastRunTime()))); + .withValues(List.of(getLastRunTimeString(runBackendStepInput)))); queryFilter.addCriteria(new QFilterCriteria() .withFieldName(runBackendStepInput.getValueString(RunProcessAction.BASEPULL_TIMESTAMP_FIELD)) .withOperator(QCriteriaOperator.LESS_THAN_OR_EQUALS) - .withValues(List.of(runBackendStepInput.getValueInstant(RunProcessAction.BASEPULL_THIS_RUNTIME_KEY)))); + .withValues(List.of(getThisRunTimeString(runBackendStepInput)))); queryFilter.addOrderBy(new QFilterOrderBy(runBackendStepInput.getValueString(RunProcessAction.BASEPULL_TIMESTAMP_FIELD))); return (queryFilter); } + + + + /******************************************************************************* + ** + *******************************************************************************/ + protected String getLastRunTimeString(RunBackendStepInput runBackendStepInput) throws QException + { + return (runBackendStepInput.getBasepullLastRunTime().toString()); + } + + + + /******************************************************************************* + ** + *******************************************************************************/ + protected String getThisRunTimeString(RunBackendStepInput runBackendStepInput) throws QException + { + return (runBackendStepInput.getValueInstant(RunProcessAction.BASEPULL_THIS_RUNTIME_KEY).toString()); + } }