Method NextExecutionTime

trigger.go:67–107

(ctx TriggerContext)

}

func (trigger *CronTrigger) NextExecutionTime(ctx TriggerContext) time.Time {
	now := time.Now()
	lastCompletion := ctx.LastCompletionTime()

	if !lastCompletion.IsZero() {

		lastExecution := ctx.LastTriggeredExecutionTime()

		if !lastExecution.IsZero() && now.Before(lastExecution) {
			now = lastExecution
		}

	}

	originalLocation := now.Location()

	convertedTime := now.In(trigger.location)
	convertedTime = time.Date(convertedTime.Year(),
		convertedTime.Month(),
		convertedTime.Day(),
		convertedTime.Hour(),
		convertedTime.Minute(),
		convertedTime.Second(),
		convertedTime.Nanosecond(),
		trigger.location)

	next := trigger.cronExpression.NextTime(convertedTime)

	// there is a bug causes timezone changing when an operation is performed on time value like add, subtraction
	// to resolve this issue, we use a workaround solution
	next = time.Date(next.Year(),
		next.Month(),
		next.Day(),
		next.Hour(),
		next.Minute(),
		next.Second(),
		next.Nanosecond(),
		trigger.location)

	return next.In(originalLocation)
}