【进阶实战】资产追踪：顶级装备的流向监控封装

local WATCH_VALUE = 1000000
local function isWatched(itemId, value)
    return value >= WATCH_VALUE or string.find(itemId, "+7", 1, true) ~= nil
    or string.find(itemId, "+8", 1, true) ~= nil
end
local function traceFlow(uniqueId, event, fromName, toName)
    local row = os.date("%m%d%H%M") .. "|" .. event .. "|" ..
        (fromName or "-") .. "->" .. (toName or "-")
    local chain = getplayvar(nil, "GLOBAL", "Flow_" .. uniqueId) or ""
    setsysvarex("Flow_" .. uniqueId, chain .. row .. "|", 1)
end
local function queryFlow(uniqueId)
    local chain = getsysvar("Flow_" .. uniqueId) or ""
    local rows = {}
    for r in string.gmatch(chain, "[^|]+") do
        rows[#rows + 1] = r
    end
    return rows
end

local function onTradeDone(uniqueId, value, seller, buyer)
    if isWatched(uniqueId, value) then
        traceFlow(uniqueId, "交易", seller, buyer)
        local rows = queryFlow(uniqueId)
        if #rows >= 3 then
            sendmsg(nil, 1, "装备 " .. uniqueId .. " 短期多次转手，已标记审查。")
        end
    end
end