-
Notifications
You must be signed in to change notification settings - Fork 78
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
PRESIDECMS-2972 refactor cron functionality into a shared lib
and use in various places that were relying on jars that no longer exist in the project.
- Loading branch information
1 parent
4564f16
commit 312f3fb
Showing
8 changed files
with
153 additions
and
161 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,99 @@ | ||
| /** | ||
| * Service providing cron parsing and other cron related utility functions | ||
| * | ||
| * @singleton true | ||
| * @presideService true | ||
| */ | ||
| component displayName="Cron util" { | ||
|
|
||
| // CONSTRUCTOR | ||
| public any function init() { | ||
| _setupCronParser(); | ||
| _setupTimezoneOffset(); | ||
|
|
||
| return this; | ||
| } | ||
|
|
||
| // PUBLIC API METHODS | ||
| public string function validateExpression( required string crontabExpression ) { | ||
| try { | ||
| _getCrontabExpressionObject( arguments.cronTabExpression ); | ||
| } catch ( any e ) { | ||
| return e.message; | ||
| } | ||
|
|
||
| return ""; | ||
| } | ||
|
|
||
| public string function getNextRunDate( required string crontabExpression, date lastRun=Now() ) { | ||
| var cronTabExpression = _getCrontabExpressionObject( arguments.crontabExpression ); | ||
| var executionTimeObj = CreateObject( "java", "com.cronutils.model.time.ExecutionTime", _getLib() ).forCron( cronTabExpression ); | ||
|
|
||
| return executionTimeObj.nextExecution( _createJavaZonedTimeObject( arguments.lastRun ) ).get().toString(); | ||
| } | ||
|
|
||
| public string function describeCronTabExression( required string crontabExpression, required string locale ) { | ||
| if ( arguments.crontabExpression == "disabled" ) { | ||
| return "disabled"; | ||
| } | ||
|
|
||
| var locale = CreateObject( "java", "java.util.Locale" ).of( UCase( ListFirst( arguments.locale, "-" ) ) ); | ||
| var cronObj = _getCrontabExpressionObject( arguments.crontabExpression ); | ||
| var descriptor = CreateObject( "java", "com.cronutils.descriptor.CronDescriptor", _getLib() ).instance( locale ); | ||
|
|
||
| return descriptor.describe( cronObj ); | ||
| } | ||
|
|
||
|
|
||
| // PRIVATE HELPERS | ||
| private any function _createJavaZonedTimeObject( required date cfmlDateTime ) { | ||
| var formatted = DateFormat( arguments.cfmlDateTime, "yyyy-mm-dd" ) & "T" | ||
| & TimeFormat( arguments.cfmlDateTime, "HH:mm:ss" ) & variables._timezoneOffset; | ||
|
|
||
| return CreateObject( "java", "java.time.ZonedDateTime" ).parse( formatted ); | ||
| } | ||
|
|
||
| private any function _getCrontabExpressionObject( required string expression ) { | ||
| return variables._cronParser.parse( _convertToValidQuartzCron( arguments.expression ) ); | ||
| } | ||
|
|
||
| private array function _getLib() { | ||
| return [ "/preside/system/services/taskmanager/lib/cron-utils-9.2.1.jar" ]; | ||
| } | ||
|
|
||
| private string function _convertToValidQuartzCron( expression ) { | ||
| var expressions = ListToArray( arguments.expression, " " ); | ||
|
|
||
| // quartz does not allow both day of month and day of week | ||
| // replace one if both used with ? | ||
| if ( ArrayLen( expressions ) >= 6 ) { | ||
| if ( expressions[ 4 ] == "*" && expressions[ 6 ] != "?" ) { | ||
| expressions[ 4 ] = "?"; | ||
| } else if ( expressions[ 4 ] != "?" ) { | ||
| expressions[ 6 ] = "?" | ||
| } | ||
| } | ||
|
|
||
| return ArrayToList( expressions, " " ); | ||
| } | ||
|
|
||
| private void function _setupCronParser() { | ||
| var cronTypes = CreateObject( "java", "com.cronutils.model.CronType", _getLib() ); | ||
| var defBuilder = CreateObject( "java", "com.cronutils.model.definition.CronDefinitionBuilder", _getLib() ); | ||
| var def = defBuilder.instanceDefinitionFor( cronTypes.QUARTZ ); | ||
|
|
||
| variables._cronParser = CreateObject( "java", "com.cronutils.parser.CronParser", _getLib() ).init( def ); | ||
| } | ||
|
|
||
| private void function _setupTimezoneOffset() { | ||
| var tzInfo = GetTimeZoneInfo(); | ||
| var hours = NumberFormat( tzInfo.utcHourOffset, "00" ); | ||
| var mins = NumberFormat( tzInfo.utcMinuteOffset, "00" ); | ||
|
|
||
| variables._timezoneOffset = "#hours#:#mins#"; | ||
| if ( Left( variables._timezoneOffset, "1" ) != "-" ) { | ||
| variables._timezoneOffset = "+" & variables._timezoneOffset; | ||
| } | ||
| } | ||
|
|
||
| } |
Oops, something went wrong.