fs25-adsmartpickup/FS25_ADSmartPickup/adFieldJobs.lua

-- AD Field Jobs
-- Markarbejdets job-løkke (hvert sekund): opdater markerne, start kæder og pleje, beslut hvilke sæt der
-- skal ud, og gå videre til næste trin. decide() er ren og testet; udsendelse og opfølgning af sættene
-- (AutoDrive/Courseplay) ligger i adFieldWork. Alt spil-nært er pcall'et pr. mark og pr. sæt.

ADFieldJobs = {}

ADFieldJobs.LOG_PREFIX = "ADSmartPickup: "
ADFieldJobs.TICK_MS = 1000
-- Courseplay kan efterlade hjørner på skæve marker: efter så mange færdige ture pr. sæt går marken videre.
ADFieldJobs.MAX_PASSES = 2
ADFieldJobs.state = {fields = {}, fleet = {}, assignments = {}}
-- mark-id -> {mower = kursus, rake = kursus, <trin> = fælles multi-tool-kursus}: kopier (kun i hukommelsen;
-- efter genindlæsning hentes slå-/rivekurset fra maskinen, som CP selv gemmer kurset på)
ADFieldJobs.courses = {}
ADFieldJobs.finished = {}
ADFieldJobs.timer = 0
ADFieldJobs.now = 0
ADFieldJobs.loaded = false

ADFieldJobs.ACTIVE_PHASES = {driving = true, starting = true, waitingCourse = true, working = true}

-- ---- ren beslutning ----

-- Er afgrøden taget (trin med afgrøde)? Slåning: under 50 % står. Høst: marken er bar eller under 50 %.
local function cropGone(stage, info)
    if info == nil then return false end
    if stage == "harvesting" and info.kind == "bare" then return true end
    return (info.readyRatio or 0) < ADFieldModel.CUT_RATIO
end

-- Beslutning for én mark. assignments = sæt på marken ({phase, stage, helper}); kun sæt på det aktuelle
-- trin tæller (en aflæsningsvogn på vej hjem fra høsten forstyrrer ikke kultiveringen).
-- Svar: {action = "start"|"care"|"advance"|"dispatch"|"wait"|"none", role, count, helper, stage, care}.
function ADFieldJobs.decide(field, info, assignments, now)
    local hasMarker = info ~= nil and info.markerId ~= nil
    if field.stage == "ready" then
        if not ADFieldModel.shouldStart(field) then return {action = "none"} end
        if not hasMarker then return {action = "wait"} end
        return {action = "start"}
    end
    if not ADFieldModel.isWorking(field) then
        local care = ADFieldModel.careNeed(field, info)
        if care == nil then return {action = "none"} end
        if field.plan.mode ~= "auto" and not field.startRequested then return {action = "none", care = care} end
        if not hasMarker then return {action = "wait", care = care} end
        return {action = "care", stage = care}
    end
    local active, finished, helpers = 0, 0, 0
    for _, assignment in ipairs(assignments) do
        if assignment.stage == nil or assignment.stage == field.stage then
            local isActive = ADFieldJobs.ACTIVE_PHASES[assignment.phase]
            if assignment.helper then
                if isActive then helpers = helpers + 1 end
            else
                if isActive then active = active + 1 end
                if assignment.phase == "finished" then finished = finished + 1 end
            end
        end
    end
    local isCropStage = ADFieldModel.CROP_STAGES[field.stage] == true
    if active == 0 then
        -- afgrøden er væk (sluppet undervejs, genindlæst, eller færdig): videre
        if isCropStage and cropGone(field.stage, info) then return {action = "advance"} end
        if finished > 0 then
            local maxPasses = ADFieldJobs.MAX_PASSES * ADFieldModel.maxRigs(field.stage, field.plan)
            if not isCropStage or finished >= maxPasses then return {action = "advance"} end
        end
        if not hasMarker then return {action = "wait"} end
        if (field.retryAt or 0) > now then return {action = "none"} end
        return {action = "dispatch", role = ADFieldModel.roleFor(field.stage), count = ADFieldModel.maxRigs(field.stage, field.plan), helper = false}
    end
    -- hovedsættene arbejder: fyld op med hjælpere (aflæsningsvogne) en ad gangen
    local helperRole = ADFieldModel.helperFor(field.stage)
    if helperRole ~= nil and helpers < ADFieldModel.maxHelpers(field.stage, field.plan) and hasMarker and (field.retryAt or 0) <= now then
        return {action = "dispatch", role = helperRole, count = 1, helper = true}
    end
    return {action = "none"}
end

-- ---- tilstand ----

function ADFieldJobs.log(fieldId, fmt, ...)
    Logging.info(ADFieldJobs.LOG_PREFIX .. "F%s " .. fmt, tostring(fieldId), ...)
end

function ADFieldJobs.getField(id)
    return ADFieldJobs.state.fields[id] or ADFieldModel.newField(id)
end

function ADFieldJobs.setField(field)
    ADFieldJobs.state.fields[field.id] = field
end

-- Ændr felter på marken (kopi via modellen).
function ADFieldJobs.note(fieldId, changes)
    ADFieldJobs.setField(ADFieldModel.with(ADFieldJobs.getField(fieldId), changes))
end

function ADFieldJobs.assignmentsFor(fieldId)
    local list = {}
    for _, assignment in pairs(ADFieldJobs.state.assignments) do
        if assignment.fieldId == fieldId then table.insert(list, assignment) end
    end
    return list
end

function ADFieldJobs.save()
    local ok, err = pcall(ADFieldStorage.save, ADFieldJobs.state)
    if not ok then Logging.warning(ADFieldJobs.LOG_PREFIX .. "marker kunne ikke gemmes: %s", tostring(err)) end
end

function ADFieldJobs.load()
    local ok, loaded = pcall(ADFieldStorage.load)
    if ok then
        ADFieldJobs.state.fields, ADFieldJobs.state.fleet = loaded.fields, loaded.fleet
    else
        Logging.warning(ADFieldJobs.LOG_PREFIX .. "marker kunne ikke indlæses: %s", tostring(loaded))
    end
    ADFieldJobs.loaded = true
end

function ADFieldJobs.setPlan(id, changes)
    ADFieldJobs.note(id, {plan = changes})
    ADFieldJobs.save()
end

function ADFieldJobs.requestStart(id)
    ADFieldJobs.note(id, {startRequested = true})
end

function ADFieldJobs.forceReady(id)
    ADFieldJobs.setField(ADFieldModel.forceReady(ADFieldJobs.getField(id)))
end

function ADFieldJobs.toggleFleet(vehicleId)
    ADFieldJobs.state.fleet = ADFieldFleet.toggle(ADFieldJobs.state.fleet, vehicleId)
    ADFieldJobs.save()
end

-- GUI'et henter flåde og gæringssiloer herfra (ligger i adFieldWork).
function ADFieldJobs.getRigs(adEnv) return ADFieldWork.getRigs(adEnv) end
function ADFieldJobs.getFermenters(...) return ADFieldWork.getFermenters(...) end

function ADFieldJobs.forgetFinished(fieldId)
    local remaining = {}
    for _, done in ipairs(ADFieldJobs.finished) do
        if done.fieldId ~= fieldId then table.insert(remaining, done) end
    end
    ADFieldJobs.finished = remaining
end

local function finishedFor(fieldId)
    local list = {}
    for _, assignment in ipairs(ADFieldJobs.finished) do
        if assignment.fieldId == fieldId then table.insert(list, assignment) end
    end
    return list
end

function ADFieldJobs.stopField(adEnv, id)
    ADFieldWork.stopAll(adEnv, id)
    ADFieldJobs.forgetFinished(id)
    ADFieldJobs.setField(ADFieldModel.stop(ADFieldJobs.getField(id)))
    ADFieldJobs.save()
    ADFieldJobs.log(id, "stoppet fra menuen")
end

-- Seneste beslutning pr. mark (GUI viser pleje-behov og grunde).
ADFieldJobs.lastDecision = {}

local function stepField(adEnv, info)
    local field = ADFieldModel.onReadiness(ADFieldJobs.getField(info.id), info.readyRatio or 0)
    ADFieldJobs.setField(field)
    local assignments = ADFieldJobs.assignmentsFor(info.id)
    for _, done in ipairs(finishedFor(info.id)) do table.insert(assignments, done) end
    local decision = ADFieldJobs.decide(field, info, assignments, ADFieldJobs.now)
    ADFieldJobs.lastDecision[info.id] = decision
    if decision.action == "start" then
        local started = ADFieldModel.start(field, info.kind, info.needs)
        started.lastFruit = info.kind == "harvest" and info.fruitName or field.lastFruit
        ADFieldJobs.setField(started)
        ADFieldJobs.log(info.id, "starter (%s: %s)", tostring(info.kind), started.stage)
        ADFieldJobs.save()
    elseif decision.action == "care" then
        ADFieldJobs.setField(ADFieldModel.startCare(field, decision.stage))
        ADFieldJobs.log(info.id, "pleje: %s", decision.stage)
        ADFieldJobs.save()
    elseif decision.action == "advance" then
        local nextField = ADFieldModel.advance(field, info.needs)
        ADFieldJobs.setField(nextField)
        ADFieldJobs.forgetFinished(info.id)
        ADFieldWork.windDownHelpers(adEnv, info.id, field.stage)
        ADFieldJobs.log(info.id, "%s -> %s", field.stage, nextField.stage)
        ADFieldJobs.save()
    elseif decision.action == "dispatch" then
        ADFieldWork.dispatch(adEnv, field, info, decision)
    end
end

function ADFieldJobs.tick(adEnv, dt)
    ADFieldJobs.now = ADFieldJobs.now + dt
    ADFieldJobs.timer = ADFieldJobs.timer + dt
    if ADFieldJobs.timer < ADFieldJobs.TICK_MS then return end
    ADFieldJobs.timer = 0
    if not ADFieldJobs.loaded then ADFieldJobs.load() end
    local farmId = g_currentMission:getFarmId()
    ADFields.scanNext(adEnv, farmId)
    for _, assignment in pairs(ADFieldJobs.state.assignments) do
        local ok, err = pcall(ADFieldWork.follow, adEnv, assignment)
        if not ok then
            Logging.warning(ADFieldJobs.LOG_PREFIX .. "F%s opfølgning fejlede: %s", tostring(assignment.fieldId), tostring(err))
            ADFieldWork.release(assignment)
        end
    end
    for _, info in ipairs(ADFields.list()) do
        local ok, err = pcall(stepField, adEnv, info)
        if not ok then Logging.warning(ADFieldJobs.LOG_PREFIX .. "F%s fejl: %s", tostring(info.id), tostring(err)) end
    end
end