payfrit-works/api/admin/scheduledTasks/runDue.cfm

<cfsetting showdebugoutput="false" requesttimeout="60">
<cfsetting enablecfoutputonly="true">
<cfcontent type="application/json; charset=utf-8" reset="true">

<cfscript>
// Process all due scheduled tasks
// Called by cron every minute (or manually for testing)
// Creates Tasks entries for any ScheduledTaskDefinitions that are due
// Public endpoint - no auth required (should be restricted by IP in production)

function apiAbort(required struct payload) {
    writeOutput(serializeJSON(payload));
    abort;
}

// Calculate next run time from cron expression
function calculateNextRun(required string cronExpression) {
    var parts = listToArray(cronExpression, " ");
    if (arrayLen(parts) != 5) {
        return dateAdd("d", 1, now());
    }

    var cronMinute = parts[1];
    var cronHour = parts[2];
    var cronDay = parts[3];
    var cronMonth = parts[4];
    var cronWeekday = parts[5];

    // Start from current time + 1 minute
    var checkDate = dateAdd("n", 1, now());
    checkDate = createDateTime(year(checkDate), month(checkDate), day(checkDate), hour(checkDate), minute(checkDate), 0);

    var maxIterations = 400 * 24 * 60; // 400 days in minutes
    var iterations = 0;

    while (iterations < maxIterations) {
        var matchMinute = (cronMinute == "*" || (isNumeric(cronMinute) && minute(checkDate) == int(cronMinute)));
        var matchHour = (cronHour == "*" || (isNumeric(cronHour) && hour(checkDate) == int(cronHour)));
        var matchDay = (cronDay == "*" || (isNumeric(cronDay) && day(checkDate) == int(cronDay)));
        var matchMonth = (cronMonth == "*" || (isNumeric(cronMonth) && month(checkDate) == int(cronMonth)));

        var dow = dayOfWeek(checkDate) - 1; // Convert to 0-based (0=Sunday)
        var matchWeekday = (cronWeekday == "*");
        if (!matchWeekday) {
            if (find("-", cronWeekday)) {
                var range = listToArray(cronWeekday, "-");
                if (arrayLen(range) == 2 && isNumeric(range[1]) && isNumeric(range[2])) {
                    matchWeekday = (dow >= int(range[1]) && dow <= int(range[2]));
                }
            } else if (isNumeric(cronWeekday)) {
                matchWeekday = (dow == int(cronWeekday));
            }
        }

        if (matchMinute && matchHour && matchDay && matchMonth && matchWeekday) {
            return checkDate;
        }

        checkDate = dateAdd("n", 1, checkDate);
        iterations++;
    }

    return dateAdd("d", 1, now());
}

try {
    // Find all active scheduled tasks that are due
    dueTasks = queryExecute("
        SELECT
            ScheduledTaskID,
            ScheduledTaskBusinessID as BusinessID,
            ScheduledTaskCategoryID as CategoryID,
            ScheduledTaskTypeID as TypeID,
            ScheduledTaskTitle as Title,
            ScheduledTaskDetails as Details,
            ScheduledTaskCronExpression as CronExpression
        FROM ScheduledTaskDefinitions
        WHERE ScheduledTaskIsActive = 1
          AND ScheduledTaskNextRunOn <= NOW()
    ", {}, { datasource: "payfrit" });

    createdTasks = [];

    for (task in dueTasks) {
        // Create the actual task
        queryExecute("
            INSERT INTO Tasks (
                TaskBusinessID, TaskCategoryID, TaskTypeID,
                TaskTitle, TaskDetails, TaskStatusID, TaskAddedOn,
                TaskSourceType, TaskSourceID
            ) VALUES (
                :businessID, :categoryID, :typeID,
                :title, :details, 0, NOW(),
                'scheduled', :scheduledTaskID
            )
        ", {
            businessID: { value: task.BusinessID, cfsqltype: "cf_sql_integer" },
            categoryID: { value: task.CategoryID, cfsqltype: "cf_sql_integer", null: isNull(task.CategoryID) },
            typeID: { value: task.TypeID, cfsqltype: "cf_sql_integer", null: isNull(task.TypeID) },
            title: { value: task.Title, cfsqltype: "cf_sql_varchar" },
            details: { value: task.Details, cfsqltype: "cf_sql_longvarchar", null: isNull(task.Details) },
            scheduledTaskID: { value: task.ScheduledTaskID, cfsqltype: "cf_sql_integer" }
        }, { datasource: "payfrit" });

        qNew = queryExecute("SELECT LAST_INSERT_ID() as newID", [], { datasource: "payfrit" });

        // Calculate next run and update the scheduled task
        nextRun = calculateNextRun(task.CronExpression);

        queryExecute("
            UPDATE ScheduledTaskDefinitions SET
                ScheduledTaskLastRunOn = NOW(),
                ScheduledTaskNextRunOn = :nextRun
            WHERE ScheduledTaskID = :id
        ", {
            nextRun: { value: nextRun, cfsqltype: "cf_sql_timestamp" },
            id: { value: task.ScheduledTaskID, cfsqltype: "cf_sql_integer" }
        }, { datasource: "payfrit" });

        arrayAppend(createdTasks, {
            "ScheduledTaskID": task.ScheduledTaskID,
            "TaskID": qNew.newID,
            "BusinessID": task.BusinessID,
            "Title": task.Title
        });
    }

    apiAbort({
        "OK": true,
        "MESSAGE": "Processed #arrayLen(createdTasks)# scheduled task(s)",
        "CREATED_TASKS": createdTasks,
        "CHECKED_COUNT": dueTasks.recordCount,
        "RAN_AT": dateTimeFormat(now(), "yyyy-mm-dd HH:nn:ss")
    });

} catch (any e) {
    apiAbort({
        "OK": false,
        "ERROR": "server_error",
        "MESSAGE": e.message
    });
}
</cfscript>