QRunIO/qqq
2
0
Fork 0
mirror of https://github.com/Kingsrook/qqq.git synced 2025-07-18 05:01:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

sprint-14: moved getting of timestamps into their own methods that can be overridden by subclasses

Browse Source
This commit is contained in:
Tim Chamberlain
2022-10-27 13:17:38 -05:00
parent 80af7a3710
commit 622183e276
1 changed files with 22 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/processes/implementations/basepull/ExtractViaBasepullQueryStep.java
View File

@ -68,15 +68,35 @@ public class ExtractViaBasepullQueryStep extends ExtractViaQueryStep
queryFilter.addCriteria(new QFilterCriteria() queryFilter.addCriteria(new QFilterCriteria()
.withFieldName(runBackendStepInput.getValueString(RunProcessAction.BASEPULL_TIMESTAMP_FIELD)) .withFieldName(runBackendStepInput.getValueString(RunProcessAction.BASEPULL_TIMESTAMP_FIELD))
.withOperator(QCriteriaOperator.GREATER_THAN) .withOperator(QCriteriaOperator.GREATER_THAN)
.withValues(List.of(runBackendStepInput.getBasepullLastRunTime()))); .withValues(List.of(getLastRunTimeString(runBackendStepInput))));
queryFilter.addCriteria(new QFilterCriteria() queryFilter.addCriteria(new QFilterCriteria()
.withFieldName(runBackendStepInput.getValueString(RunProcessAction.BASEPULL_TIMESTAMP_FIELD)) .withFieldName(runBackendStepInput.getValueString(RunProcessAction.BASEPULL_TIMESTAMP_FIELD))
.withOperator(QCriteriaOperator.LESS_THAN_OR_EQUALS) .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))); queryFilter.addOrderBy(new QFilterOrderBy(runBackendStepInput.getValueString(RunProcessAction.BASEPULL_TIMESTAMP_FIELD)));
return (queryFilter); 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());
}
} }