710 lines
25 KiB
C++
710 lines
25 KiB
C++
#include "Debug.h"
|
|
#include "LuaTools.h"
|
|
#include "PluginManager.h"
|
|
|
|
#include "modules/Buildings.h"
|
|
#include "modules/Job.h"
|
|
#include "modules/Persistence.h"
|
|
#include "modules/World.h"
|
|
|
|
#include "df/building.h"
|
|
#include "df/building_stockpilest.h"
|
|
#include "df/building_tradedepotst.h"
|
|
#include "df/caravan_state.h"
|
|
#include "df/general_ref_building_holderst.h"
|
|
#include "df/plotinfost.h"
|
|
#include "df/world.h"
|
|
|
|
using std::string;
|
|
using std::unordered_map;
|
|
using std::vector;
|
|
|
|
using namespace DFHack;
|
|
|
|
DFHACK_PLUGIN("logistics");
|
|
|
|
DFHACK_PLUGIN_IS_ENABLED(is_enabled);
|
|
|
|
REQUIRE_GLOBAL(plotinfo);
|
|
REQUIRE_GLOBAL(world);
|
|
|
|
namespace DFHack {
|
|
DBG_DECLARE(logistics, status, DebugCategory::LINFO);
|
|
DBG_DECLARE(logistics, cycle, DebugCategory::LINFO);
|
|
}
|
|
|
|
static const string CONFIG_KEY_PREFIX = string(plugin_name) + "/";
|
|
static unordered_map<int32_t, PersistentDataItem> watched_stockpiles;
|
|
|
|
enum StockpileConfigValues {
|
|
STOCKPILE_CONFIG_STOCKPILE_NUMBER = 0,
|
|
STOCKPILE_CONFIG_MELT = 1,
|
|
STOCKPILE_CONFIG_TRADE = 2,
|
|
STOCKPILE_CONFIG_DUMP = 3,
|
|
};
|
|
|
|
static int get_config_val(PersistentDataItem& c, int index) {
|
|
if (!c.isValid())
|
|
return -1;
|
|
return c.ival(index);
|
|
}
|
|
|
|
static bool get_config_bool(PersistentDataItem& c, int index) {
|
|
return get_config_val(c, index) == 1;
|
|
}
|
|
|
|
static void set_config_val(PersistentDataItem& c, int index, int value) {
|
|
if (c.isValid())
|
|
c.ival(index) = value;
|
|
}
|
|
|
|
static void set_config_bool(PersistentDataItem& c, int index, bool value) {
|
|
set_config_val(c, index, value ? 1 : 0);
|
|
}
|
|
|
|
static PersistentDataItem& ensure_stockpile_config(color_ostream& out, int stockpile_number) {
|
|
DEBUG(cycle, out).print("ensuring stockpile config stockpile_number=%d\n", stockpile_number);
|
|
if (watched_stockpiles.count(stockpile_number)) {
|
|
DEBUG(cycle, out).print("stockpile exists in watched_stockpiles\n");
|
|
return watched_stockpiles[stockpile_number];
|
|
}
|
|
|
|
string keyname = CONFIG_KEY_PREFIX + int_to_string(stockpile_number);
|
|
DEBUG(status, out).print("creating new persistent key for stockpile %d\n", stockpile_number);
|
|
watched_stockpiles.emplace(stockpile_number, World::GetPersistentData(keyname, NULL));
|
|
PersistentDataItem& c = watched_stockpiles[stockpile_number];
|
|
set_config_val(c, STOCKPILE_CONFIG_STOCKPILE_NUMBER, stockpile_number);
|
|
set_config_bool(c, STOCKPILE_CONFIG_MELT, false);
|
|
set_config_bool(c, STOCKPILE_CONFIG_TRADE, false);
|
|
set_config_bool(c, STOCKPILE_CONFIG_DUMP, false);
|
|
return c;
|
|
}
|
|
|
|
static void remove_stockpile_config(color_ostream& out, int stockpile_number) {
|
|
if (!watched_stockpiles.count(stockpile_number))
|
|
return;
|
|
DEBUG(status, out).print("removing persistent key for stockpile %d\n", stockpile_number);
|
|
World::DeletePersistentData(watched_stockpiles[stockpile_number]);
|
|
watched_stockpiles.erase(stockpile_number);
|
|
}
|
|
|
|
static const int32_t CYCLE_TICKS = 600;
|
|
static int32_t cycle_timestamp = 0; // world->frame_counter at last cycle
|
|
|
|
static command_result do_command(color_ostream &out, vector<string> ¶meters);
|
|
static void do_cycle(color_ostream &out, int32_t &melt_count, int32_t &trade_count, int32_t &dump_count);
|
|
|
|
DFhackCExport command_result plugin_init(color_ostream &out, vector<PluginCommand> &commands) {
|
|
DEBUG(status, out).print("initializing %s\n", plugin_name);
|
|
|
|
commands.push_back(PluginCommand(
|
|
plugin_name,
|
|
"Automatically mark and route items in monitored stockpiles.",
|
|
do_command));
|
|
|
|
return CR_OK;
|
|
}
|
|
|
|
DFhackCExport command_result plugin_enable(color_ostream &out, bool enable) {
|
|
is_enabled = enable;
|
|
DEBUG(status, out).print("now %s\n", is_enabled ? "enabled" : "disabled");
|
|
return CR_OK;
|
|
}
|
|
|
|
static df::building_stockpilest* find_stockpile(int32_t stockpile_number) {
|
|
return binsearch_in_vector(world->buildings.other.STOCKPILE,
|
|
&df::building_stockpilest::stockpile_number, stockpile_number);
|
|
}
|
|
|
|
static void validate_stockpile_configs(color_ostream& out,
|
|
unordered_map<df::building_stockpilest *, PersistentDataItem> &cache) {
|
|
for (auto& entry : watched_stockpiles) {
|
|
int stockpile_number = entry.first;
|
|
PersistentDataItem &c = entry.second;
|
|
auto bld = find_stockpile(stockpile_number);
|
|
if (!bld || (
|
|
!get_config_bool(c, STOCKPILE_CONFIG_MELT) &&
|
|
!get_config_bool(c, STOCKPILE_CONFIG_TRADE) &&
|
|
!get_config_bool(c, STOCKPILE_CONFIG_DUMP))) {
|
|
remove_stockpile_config(out, stockpile_number);
|
|
continue;
|
|
}
|
|
cache.emplace(bld, c);
|
|
}
|
|
}
|
|
|
|
// remove this function once saves from 50.08 are no longer compatible
|
|
static void migrate_old_keys(color_ostream &out) {
|
|
vector<PersistentDataItem> old_data;
|
|
World::GetPersistentData(&old_data, "automelt/stockpile/", true);
|
|
const size_t num_old_keys = old_data.size();
|
|
for (size_t idx = 0; idx < num_old_keys; ++idx) {
|
|
auto& old_c = old_data[idx];
|
|
int32_t bld_id = get_config_val(old_c, 0);
|
|
bool melt_was_on = get_config_bool(old_c, 1);
|
|
World::DeletePersistentData(old_c);
|
|
auto bld = df::building::find(bld_id);
|
|
if (!bld || bld->getType() != df::building_type::Stockpile ||
|
|
watched_stockpiles.count(static_cast<df::building_stockpilest *>(bld)->stockpile_number))
|
|
continue;
|
|
auto &c = ensure_stockpile_config(out, static_cast<df::building_stockpilest *>(bld)->stockpile_number);
|
|
set_config_bool(c, STOCKPILE_CONFIG_MELT, melt_was_on);
|
|
}
|
|
}
|
|
|
|
DFhackCExport command_result plugin_load_data(color_ostream &out) {
|
|
cycle_timestamp = 0;
|
|
|
|
vector<PersistentDataItem> loaded_persist_data;
|
|
World::GetPersistentData(&loaded_persist_data, CONFIG_KEY_PREFIX, true);
|
|
watched_stockpiles.clear();
|
|
const size_t num_watched_stockpiles = loaded_persist_data.size();
|
|
for (size_t idx = 0; idx < num_watched_stockpiles; ++idx) {
|
|
auto& c = loaded_persist_data[idx];
|
|
watched_stockpiles.emplace(get_config_val(c, STOCKPILE_CONFIG_STOCKPILE_NUMBER), c);
|
|
}
|
|
migrate_old_keys(out);
|
|
|
|
return CR_OK;
|
|
}
|
|
|
|
DFhackCExport command_result plugin_onupdate(color_ostream &out) {
|
|
if (!is_enabled || !Core::getInstance().isWorldLoaded())
|
|
return CR_OK;
|
|
if (world->frame_counter - cycle_timestamp >= CYCLE_TICKS) {
|
|
int32_t melt_count = 0, trade_count = 0, dump_count = 0;
|
|
do_cycle(out, melt_count, trade_count, dump_count);
|
|
if (0 < melt_count)
|
|
out.print("logistics: marked %d item(s) for melting\n", melt_count);
|
|
if (0 < trade_count)
|
|
out.print("logistics: marked %d item(s) for trading\n", trade_count);
|
|
if (0 < dump_count)
|
|
out.print("logistics: marked %d item(s) for dumping\n", dump_count);
|
|
}
|
|
return CR_OK;
|
|
}
|
|
|
|
static bool call_logistics_lua(color_ostream* out, const char* fn_name,
|
|
int nargs = 0, int nres = 0,
|
|
Lua::LuaLambda && args_lambda = Lua::DEFAULT_LUA_LAMBDA,
|
|
Lua::LuaLambda && res_lambda = Lua::DEFAULT_LUA_LAMBDA) {
|
|
DEBUG(status).print("calling logistics lua function: '%s'\n", fn_name);
|
|
|
|
CoreSuspender guard;
|
|
|
|
auto L = Lua::Core::State;
|
|
Lua::StackUnwinder top(L);
|
|
|
|
if (!out)
|
|
out = &Core::getInstance().getConsole();
|
|
|
|
return Lua::CallLuaModuleFunction(*out, L, "plugins.logistics", fn_name,
|
|
nargs, nres,
|
|
std::forward<Lua::LuaLambda&&>(args_lambda),
|
|
std::forward<Lua::LuaLambda&&>(res_lambda));
|
|
}
|
|
|
|
static command_result do_command(color_ostream &out, vector<string> ¶meters) {
|
|
CoreSuspender suspend;
|
|
|
|
bool show_help = false;
|
|
if (!call_logistics_lua(&out, "parse_commandline", 1, 1,
|
|
[&](lua_State *L) {
|
|
Lua::PushVector(L, parameters);
|
|
},
|
|
[&](lua_State *L) {
|
|
show_help = !lua_toboolean(L, -1);
|
|
})) {
|
|
return CR_FAILURE;
|
|
}
|
|
|
|
return show_help ? CR_WRONG_USAGE : CR_OK;
|
|
}
|
|
|
|
/////////////////////////////////////////////////////
|
|
// cycle
|
|
//
|
|
|
|
typedef unordered_map<int32_t, size_t> StatMap;
|
|
|
|
struct ProcessorStats {
|
|
size_t newly_designated = 0;
|
|
StatMap designated_counts, can_designate_counts;
|
|
};
|
|
|
|
class StockProcessor {
|
|
public:
|
|
const string name;
|
|
const int32_t stockpile_number;
|
|
const bool enabled;
|
|
ProcessorStats &stats;
|
|
protected:
|
|
StockProcessor(const string &name, int32_t stockpile_number, bool enabled, ProcessorStats &stats)
|
|
: name(name), stockpile_number(stockpile_number), enabled(enabled), stats(stats) { }
|
|
public:
|
|
virtual bool is_designated(color_ostream &out, df::item *item) = 0;
|
|
virtual bool can_designate(color_ostream &out, df::item *item) = 0;
|
|
virtual bool designate(color_ostream &out, df::item *item) = 0;
|
|
};
|
|
|
|
class MeltStockProcessor : public StockProcessor {
|
|
public:
|
|
MeltStockProcessor(int32_t stockpile_number, bool enabled, ProcessorStats &stats)
|
|
: StockProcessor("melt", stockpile_number, enabled, stats) { }
|
|
|
|
bool is_designated(color_ostream &out, df::item *item) override {
|
|
return item->flags.bits.melt;
|
|
}
|
|
|
|
bool can_designate(color_ostream &out, df::item *item) override {
|
|
MaterialInfo mat(item);
|
|
if (mat.getCraftClass() != df::craft_material_class::Metal)
|
|
return false;
|
|
|
|
if (item->getType() == df::item_type::BAR)
|
|
return false;
|
|
|
|
for (auto &g : item->general_refs) {
|
|
switch (g->getType()) {
|
|
case df::general_ref_type::CONTAINS_ITEM:
|
|
case df::general_ref_type::UNIT_HOLDER:
|
|
case df::general_ref_type::CONTAINS_UNIT:
|
|
return false;
|
|
case df::general_ref_type::CONTAINED_IN_ITEM:
|
|
{
|
|
df::item *c = g->getItem();
|
|
for (auto &gg : c->general_refs) {
|
|
if (gg->getType() == df::general_ref_type::UNIT_HOLDER)
|
|
return false;
|
|
}
|
|
break;
|
|
}
|
|
default:
|
|
break;
|
|
}
|
|
}
|
|
|
|
if (item->getQuality() >= df::item_quality::Masterful)
|
|
return false;
|
|
|
|
return true;
|
|
}
|
|
|
|
bool designate(color_ostream &out, df::item *item) override {
|
|
insert_into_vector(world->items.other.ANY_MELT_DESIGNATED, &df::item::id, item);
|
|
item->flags.bits.melt = 1;
|
|
return true;
|
|
}
|
|
};
|
|
|
|
class TradeStockProcessor: public StockProcessor {
|
|
public:
|
|
TradeStockProcessor(int32_t stockpile_number, bool enabled, ProcessorStats& stats)
|
|
: StockProcessor("trade", stockpile_number, enabled && get_active_trade_depot(), stats),
|
|
depot(get_active_trade_depot()) { }
|
|
|
|
bool is_designated(color_ostream& out, df::item* item) override {
|
|
auto ref = Items::getSpecificRef(item, df::specific_ref_type::JOB);
|
|
return ref && ref->data.job &&
|
|
ref->data.job->job_type == df::job_type::BringItemToDepot;
|
|
}
|
|
|
|
bool can_designate(color_ostream& out, df::item* item) override {
|
|
return Items::canTradeWithContents(item);
|
|
}
|
|
|
|
bool designate(color_ostream& out, df::item* item) override {
|
|
if (!depot)
|
|
return false;
|
|
|
|
auto href = df::allocate<df::general_ref_building_holderst>();
|
|
if (!href)
|
|
return false;
|
|
|
|
auto job = new df::job();
|
|
job->job_type = df::job_type::BringItemToDepot;
|
|
job->pos = df::coord(depot->centerx, depot->centery, depot->z);
|
|
|
|
// job <-> item link
|
|
if (!Job::attachJobItem(job, item, df::job_item_ref::Hauled)) {
|
|
delete job;
|
|
delete href;
|
|
return false;
|
|
}
|
|
|
|
// job <-> building link
|
|
href->building_id = depot->id;
|
|
depot->jobs.push_back(job);
|
|
job->general_refs.push_back(href);
|
|
|
|
// add to job list
|
|
Job::linkIntoWorld(job);
|
|
|
|
return true;
|
|
}
|
|
|
|
private:
|
|
df::building_tradedepotst * const depot;
|
|
|
|
static df::building_tradedepotst * get_active_trade_depot() {
|
|
// at least one caravan must be approaching or ready to trade
|
|
if (!plotinfo->caravans.size())
|
|
return NULL;
|
|
bool found = false;
|
|
for (auto caravan : plotinfo->caravans) {
|
|
auto trade_state = caravan->trade_state;
|
|
auto time_remaining = caravan->time_remaining;
|
|
if ((trade_state == df::caravan_state::T_trade_state::Approaching ||
|
|
trade_state == df::caravan_state::T_trade_state::AtDepot) && time_remaining != 0) {
|
|
found = true;
|
|
break;
|
|
}
|
|
}
|
|
if (!found)
|
|
return NULL;
|
|
|
|
// at least one trade depot must be ready to receive goods
|
|
for (auto bld : world->buildings.other.TRADE_DEPOT) {
|
|
if (bld->getBuildStage() < bld->getMaxBuildStage())
|
|
continue;
|
|
|
|
if (bld->jobs.size() == 1 &&
|
|
bld->jobs[0]->job_type == df::job_type::DestroyBuilding)
|
|
continue;
|
|
|
|
return bld;
|
|
}
|
|
return NULL;
|
|
}
|
|
};
|
|
|
|
class DumpStockProcessor: public StockProcessor {
|
|
public:
|
|
DumpStockProcessor(int32_t stockpile_number, bool enabled, ProcessorStats& stats)
|
|
: StockProcessor("dump", stockpile_number, enabled, stats) { }
|
|
|
|
bool is_designated(color_ostream& out, df::item* item) override {
|
|
return item->flags.bits.dump;
|
|
}
|
|
|
|
bool can_designate(color_ostream& out, df::item* item) override {
|
|
return true;
|
|
}
|
|
|
|
bool designate(color_ostream& out, df::item* item) override {
|
|
item->flags.bits.dump = true;
|
|
return true;
|
|
}
|
|
};
|
|
|
|
static const struct BadFlags {
|
|
const uint32_t whole;
|
|
|
|
BadFlags() : whole(get_bad_flags()) { }
|
|
|
|
private:
|
|
uint32_t get_bad_flags() {
|
|
df::item_flags flags;
|
|
#define F(x) flags.bits.x = true;
|
|
F(forbid); F(garbage_collect); F(hostile); F(on_fire);
|
|
F(rotten); F(trader); F(in_building); F(construction);
|
|
F(artifact); F(spider_web); F(owned); F(in_job);
|
|
#undef F
|
|
return flags.whole;
|
|
}
|
|
} bad_flags;
|
|
|
|
static void scan_item(color_ostream &out, df::item *item, StockProcessor &processor) {
|
|
DEBUG(cycle,out).print("scan_item [%s] item_id=%d\n", processor.name.c_str(), item->id);
|
|
|
|
if (DBG_NAME(cycle).isEnabled(DebugCategory::LTRACE)) {
|
|
string name = "";
|
|
item->getItemDescription(&name, 0);
|
|
TRACE(cycle,out).print("item: %s\n", name.c_str());
|
|
}
|
|
|
|
if (item->flags.whole & bad_flags.whole) {
|
|
TRACE(cycle,out).print("rejected flag check\n");
|
|
return;
|
|
}
|
|
|
|
if (processor.is_designated(out, item)) {
|
|
TRACE(cycle,out).print("already designated\n");
|
|
++processor.stats.designated_counts[processor.stockpile_number];
|
|
return;
|
|
}
|
|
|
|
if (!processor.can_designate(out, item)) {
|
|
TRACE(cycle,out).print("cannot designate\n");
|
|
return;
|
|
}
|
|
|
|
if (!processor.enabled) {
|
|
++processor.stats.can_designate_counts[processor.stockpile_number];
|
|
return;
|
|
}
|
|
|
|
processor.designate(out, item);
|
|
++processor.stats.newly_designated;
|
|
++processor.stats.designated_counts[processor.stockpile_number];
|
|
}
|
|
|
|
static void scan_stockpile(color_ostream &out, df::building_stockpilest *bld,
|
|
MeltStockProcessor &melt_stock_processor,
|
|
TradeStockProcessor &trade_stock_processor,
|
|
DumpStockProcessor &dump_stock_processor) {
|
|
auto id = bld->id;
|
|
Buildings::StockpileIterator items;
|
|
for (items.begin(bld); !items.done(); ++items) {
|
|
df::item *item = *items;
|
|
scan_item(out, item, trade_stock_processor);
|
|
if (0 == (item->flags.whole & bad_flags.whole) &&
|
|
item->isAssignedToThisStockpile(id)) {
|
|
TRACE(cycle,out).print("assignedToStockpile\n");
|
|
vector<df::item *> contents;
|
|
Items::getContainedItems(item, &contents);
|
|
for (df::item *contained_item : contents) {
|
|
scan_item(out, contained_item, melt_stock_processor);
|
|
scan_item(out, contained_item, dump_stock_processor);
|
|
}
|
|
continue;
|
|
}
|
|
scan_item(out, item, melt_stock_processor);
|
|
scan_item(out, item, dump_stock_processor);
|
|
}
|
|
}
|
|
|
|
static void do_cycle(color_ostream &out, int32_t &melt_count, int32_t &trade_count, int32_t &dump_count) {
|
|
DEBUG(cycle,out).print("running %s cycle\n", plugin_name);
|
|
cycle_timestamp = world->frame_counter;
|
|
|
|
ProcessorStats melt_stats, trade_stats, dump_stats;
|
|
unordered_map<df::building_stockpilest *, PersistentDataItem> cache;
|
|
validate_stockpile_configs(out, cache);
|
|
|
|
for (auto &entry : cache) {
|
|
df::building_stockpilest *bld = entry.first;
|
|
PersistentDataItem &c = entry.second;
|
|
int32_t stockpile_number = bld->stockpile_number;
|
|
|
|
bool melt = get_config_bool(c, STOCKPILE_CONFIG_MELT);
|
|
bool trade = get_config_bool(c, STOCKPILE_CONFIG_TRADE);
|
|
bool dump = get_config_bool(c, STOCKPILE_CONFIG_DUMP);
|
|
|
|
MeltStockProcessor melt_stock_processor(stockpile_number, melt, melt_stats);
|
|
TradeStockProcessor trade_stock_processor(stockpile_number, trade, trade_stats);
|
|
DumpStockProcessor dump_stock_processor(stockpile_number, dump, dump_stats);
|
|
|
|
scan_stockpile(out, bld, melt_stock_processor,
|
|
trade_stock_processor, dump_stock_processor);
|
|
}
|
|
|
|
melt_count = melt_stats.newly_designated;
|
|
trade_count = trade_stats.newly_designated;
|
|
dump_count = dump_stats.newly_designated;
|
|
TRACE(cycle,out).print("exit %s do_cycle\n", plugin_name);
|
|
}
|
|
|
|
/////////////////////////////////////////////////////
|
|
// Lua API
|
|
//
|
|
|
|
static int logistics_getStockpileData(lua_State *L) {
|
|
color_ostream *out = Lua::GetOutput(L);
|
|
if (!out)
|
|
out = &Core::getInstance().getConsole();
|
|
DEBUG(status,*out).print("entering logistics_getStockpileData\n");
|
|
|
|
unordered_map<df::building_stockpilest *, PersistentDataItem> cache;
|
|
validate_stockpile_configs(*out, cache);
|
|
|
|
ProcessorStats melt_stats, trade_stats, dump_stats;
|
|
|
|
for (auto bld : df::global::world->buildings.other.STOCKPILE) {
|
|
int32_t stockpile_number = bld->stockpile_number;
|
|
MeltStockProcessor melt_stock_processor(stockpile_number, false, melt_stats);
|
|
TradeStockProcessor trade_stock_processor(stockpile_number, false, trade_stats);
|
|
DumpStockProcessor dump_stock_processor(stockpile_number, false, dump_stats);
|
|
|
|
scan_stockpile(*out, bld, melt_stock_processor,
|
|
trade_stock_processor, dump_stock_processor);
|
|
}
|
|
|
|
unordered_map<string, StatMap> stats;
|
|
stats.emplace("melt_designated", melt_stats.designated_counts);
|
|
stats.emplace("melt_can_designate", melt_stats.can_designate_counts);
|
|
stats.emplace("trade_designated", trade_stats.designated_counts);
|
|
stats.emplace("trade_can_designate", trade_stats.can_designate_counts);
|
|
stats.emplace("dump_designated", dump_stats.designated_counts);
|
|
stats.emplace("dump_can_designate", dump_stats.can_designate_counts);
|
|
Lua::Push(L, stats);
|
|
|
|
unordered_map<int32_t, unordered_map<string, string>> configs;
|
|
for (auto &entry : cache) {
|
|
df::building_stockpilest *bld = entry.first;
|
|
PersistentDataItem &c = entry.second;
|
|
|
|
bool melt = get_config_bool(c, STOCKPILE_CONFIG_MELT);
|
|
bool trade = get_config_bool(c, STOCKPILE_CONFIG_TRADE);
|
|
bool dump = get_config_bool(c, STOCKPILE_CONFIG_DUMP);
|
|
|
|
unordered_map<string, string> config;
|
|
config.emplace("melt", melt ? "true" : "false");
|
|
config.emplace("trade", trade ? "true" : "false");
|
|
config.emplace("dump", dump ? "true" : "false");
|
|
|
|
configs.emplace(bld->stockpile_number, config);
|
|
}
|
|
Lua::Push(L, configs);
|
|
|
|
TRACE(cycle, *out).print("exit logistics_getStockpileData\n");
|
|
|
|
return 2;
|
|
}
|
|
|
|
static void logistics_cycle(color_ostream &out) {
|
|
DEBUG(status, out).print("entering logistics_cycle\n");
|
|
int32_t melt_count = 0, trade_count = 0, dump_count = 0;
|
|
do_cycle(out, melt_count, trade_count, dump_count);
|
|
out.print("logistics: marked %d item(s) for melting\n", melt_count);
|
|
out.print("logistics: marked %d item(s) for trading\n", trade_count);
|
|
out.print("logistics: marked %d item(s) for dumping\n", dump_count);
|
|
}
|
|
|
|
static void find_stockpiles(lua_State *L, int idx,
|
|
vector<df::building_stockpilest*> &sps) {
|
|
if (lua_isnumber(L, idx)) {
|
|
sps.emplace_back(find_stockpile(lua_tointeger(L, -1)));
|
|
return;
|
|
}
|
|
|
|
const char * pname = lua_tostring(L, -1);
|
|
if (!pname || !*pname)
|
|
return;
|
|
string name(pname);
|
|
for (auto sp : world->buildings.other.STOCKPILE) {
|
|
if (name == sp->name)
|
|
sps.emplace_back(sp);
|
|
}
|
|
}
|
|
|
|
static unordered_map<string, int> get_stockpile_config(int32_t stockpile_number) {
|
|
unordered_map<string, int> stockpile_config;
|
|
stockpile_config.emplace("stockpile_number", stockpile_number);
|
|
if (watched_stockpiles.count(stockpile_number)) {
|
|
PersistentDataItem &c = watched_stockpiles[stockpile_number];
|
|
stockpile_config.emplace("melt", get_config_bool(c, STOCKPILE_CONFIG_MELT));
|
|
stockpile_config.emplace("trade", get_config_bool(c, STOCKPILE_CONFIG_TRADE));
|
|
stockpile_config.emplace("dump", get_config_bool(c, STOCKPILE_CONFIG_DUMP));
|
|
} else {
|
|
stockpile_config.emplace("melt", false);
|
|
stockpile_config.emplace("trade", false);
|
|
stockpile_config.emplace("dump", false);
|
|
}
|
|
return stockpile_config;
|
|
}
|
|
|
|
static int logistics_getStockpileConfigs(lua_State *L) {
|
|
color_ostream *out = Lua::GetOutput(L);
|
|
if (!out)
|
|
out = &Core::getInstance().getConsole();
|
|
DEBUG(status, *out).print("entering logistics_getStockpileConfig\n");
|
|
|
|
unordered_map<df::building_stockpilest*, PersistentDataItem> cache;
|
|
validate_stockpile_configs(*out, cache);
|
|
|
|
vector<df::building_stockpilest*> sps;
|
|
find_stockpiles(L, -1, sps);
|
|
if (sps.empty())
|
|
return 0;
|
|
|
|
vector<unordered_map<string, int>> configs;
|
|
for (auto sp : sps)
|
|
configs.emplace_back(get_stockpile_config(sp->stockpile_number));
|
|
Lua::PushVector(L, configs);
|
|
return 1;
|
|
}
|
|
|
|
static void logistics_setStockpileConfig(color_ostream &out, int stockpile_number, bool melt, bool trade, bool dump) {
|
|
DEBUG(status, out).print("entering logistics_setStockpileConfig stockpile_number=%d, melt=%d, trade=%d, dump=%d\n",
|
|
stockpile_number, melt, trade, dump);
|
|
|
|
if (!find_stockpile(stockpile_number)) {
|
|
out.printerr("invalid stockpile number: %d\n", stockpile_number);
|
|
return;
|
|
}
|
|
|
|
auto &c = ensure_stockpile_config(out, stockpile_number);
|
|
set_config_bool(c, STOCKPILE_CONFIG_MELT, melt);
|
|
set_config_bool(c, STOCKPILE_CONFIG_TRADE, trade);
|
|
set_config_bool(c, STOCKPILE_CONFIG_DUMP, dump);
|
|
}
|
|
|
|
static int logistics_clearStockpileConfig(lua_State *L) {
|
|
color_ostream *out = Lua::GetOutput(L);
|
|
if (!out)
|
|
out = &Core::getInstance().getConsole();
|
|
DEBUG(status, *out).print("entering logistics_clearStockpileConfig\n");
|
|
|
|
vector<df::building_stockpilest*> sps;
|
|
find_stockpiles(L, -1, sps);
|
|
if (sps.empty())
|
|
return 0;
|
|
|
|
for (auto sp : sps)
|
|
remove_stockpile_config(*out, sp->stockpile_number);
|
|
return 0;
|
|
}
|
|
|
|
static void logistics_clearAllStockpileConfigs(color_ostream &out) {
|
|
DEBUG(status, out).print("entering logistics_clearAllStockpileConfigs\n");
|
|
for (auto &entry : watched_stockpiles)
|
|
World::DeletePersistentData(entry.second);
|
|
watched_stockpiles.clear();
|
|
}
|
|
|
|
static int logistics_getGlobalCounts(lua_State *L) {
|
|
color_ostream *out = Lua::GetOutput(L);
|
|
if (!out)
|
|
out = &Core::getInstance().getConsole();
|
|
DEBUG(status,*out).print("entering logistics_getGlobalCounts\n");
|
|
|
|
size_t num_melt = df::global::world->items.other.ANY_MELT_DESIGNATED.size();
|
|
|
|
size_t num_trade = 0;
|
|
for (auto link = world->jobs.list.next; link; link = link->next) {
|
|
df::job *job = link->item;
|
|
if (job->job_type == df::job_type::BringItemToDepot)
|
|
++num_trade;
|
|
}
|
|
|
|
size_t num_dump = 0;
|
|
for (auto item : world->items.other.IN_PLAY) {
|
|
if (item->flags.bits.dump)
|
|
++num_dump;
|
|
}
|
|
|
|
unordered_map<string, size_t> results;
|
|
results.emplace("total_melt", num_melt);
|
|
results.emplace("total_trade", num_trade);
|
|
results.emplace("total_dump", num_dump);
|
|
Lua::Push(L, results);
|
|
|
|
TRACE(cycle, *out).print("exit logistics_getGlobalCounts\n");
|
|
|
|
return 1;
|
|
}
|
|
|
|
DFHACK_PLUGIN_LUA_FUNCTIONS{
|
|
DFHACK_LUA_FUNCTION(logistics_cycle),
|
|
DFHACK_LUA_FUNCTION(logistics_setStockpileConfig),
|
|
DFHACK_LUA_FUNCTION(logistics_clearAllStockpileConfigs),
|
|
DFHACK_LUA_END};
|
|
|
|
DFHACK_PLUGIN_LUA_COMMANDS{
|
|
DFHACK_LUA_COMMAND(logistics_getStockpileData),
|
|
DFHACK_LUA_COMMAND(logistics_getStockpileConfigs),
|
|
DFHACK_LUA_COMMAND(logistics_clearStockpileConfig),
|
|
DFHACK_LUA_COMMAND(logistics_getGlobalCounts),
|
|
DFHACK_LUA_END};
|