300 lines
9.9 KiB
Java
300 lines
9.9 KiB
Java
// • ▌ ▄ ·. ▄▄▄· ▄▄ • ▪ ▄▄· ▄▄▄▄· ▄▄▄· ▐▄▄▄ ▄▄▄ .
|
|
// ·██ ▐███▪▐█ ▀█ ▐█ ▀ ▪██ ▐█ ▌▪▐█ ▀█▪▐█ ▀█ •█▌ ▐█▐▌·
|
|
// ▐█ ▌▐▌▐█·▄█▀▀█ ▄█ ▀█▄▐█·██ ▄▄▐█▀▀█▄▄█▀▀█ ▐█▐ ▐▌▐▀▀▀
|
|
// ██ ██▌▐█▌▐█ ▪▐▌▐█▄▪▐█▐█▌▐███▌██▄▪▐█▐█ ▪▐▌██▐ █▌▐█▄▄▌
|
|
// ▀▀ █▪▀▀▀ ▀ ▀ ·▀▀▀▀ ▀▀▀·▀▀▀ ·▀▀▀▀ ▀ ▀ ▀▀ █▪ ▀▀▀
|
|
// Magicbane Emulator Project © 2013 - 2022
|
|
// www.magicbane.com
|
|
|
|
|
|
package engine.workthreads;
|
|
|
|
import engine.InterestManagement.WorldGrid;
|
|
import engine.db.archive.DataWarehouse;
|
|
import engine.db.archive.MineRecord;
|
|
import engine.gameManager.*;
|
|
import engine.mbEnums;
|
|
import engine.net.MessageDispatcher;
|
|
import engine.net.client.msg.chat.ChatSystemMsg;
|
|
import engine.objects.*;
|
|
import engine.server.world.WorldServer;
|
|
import org.joda.time.DateTime;
|
|
import org.pmw.tinylog.Logger;
|
|
|
|
import java.time.LocalDateTime;
|
|
import java.util.ArrayList;
|
|
import java.util.concurrent.ConcurrentHashMap;
|
|
|
|
import static engine.server.MBServerStatics.MINE_LATE_WINDOW;
|
|
|
|
public class HourlyJobThread implements Runnable {
|
|
|
|
public HourlyJobThread() {
|
|
|
|
}
|
|
|
|
public static void decayShrines() {
|
|
ArrayList<Shrine> shrineList = new ArrayList<>();
|
|
|
|
for (Shrine shrine : Shrine.shrinesByBuildingUUID.values()) {
|
|
try {
|
|
Building shrineBuilding = (Building) DbManager.getObject(mbEnums.GameObjectType.Building, shrine.getBuildingID());
|
|
|
|
if (shrineBuilding == null)
|
|
continue;
|
|
|
|
|
|
if (shrineBuilding.getOwner().equals(shrineBuilding.getCity().getOwner()) == false)
|
|
shrineBuilding.claim(shrineBuilding.getCity().getOwner());
|
|
} catch (Exception e) {
|
|
Logger.info("Shrine " + shrine.getBuildingID() + " Error " + e);
|
|
}
|
|
}
|
|
|
|
// Grab list of top two shrines of each type
|
|
|
|
for (Shrine shrine : Shrine.shrinesByBuildingUUID.values()) {
|
|
|
|
if (shrine.getRank() == 0 || shrine.getRank() == 1)
|
|
shrineList.add(shrine);
|
|
}
|
|
|
|
Logger.info("Decaying " + shrineList.size() + " shrines...");
|
|
|
|
// Top 2 shrines decay by 10% a day
|
|
|
|
for (Shrine shrine : shrineList) {
|
|
|
|
try {
|
|
shrine.decay();
|
|
} catch (Exception e) {
|
|
Logger.info("Shrine " + shrine.getBuildingID() + " Error " + e);
|
|
}
|
|
}
|
|
}
|
|
|
|
public static void processMineWindow() {
|
|
|
|
try {
|
|
|
|
ArrayList<Mine> mines = Mine.getMines();
|
|
|
|
for (Mine mine : mines) {
|
|
if (LocalDateTime.now().getHour() == 1400) {
|
|
mine.wasClaimed = false;
|
|
}
|
|
try {
|
|
|
|
// Open Errant Mines
|
|
|
|
if (mine.getOwningGuild().isEmptyGuild()) {
|
|
HourlyJobThread.mineWindowOpen(mine);
|
|
continue;
|
|
}
|
|
|
|
// Open Mines owned by nations having their WOO
|
|
// set to the current mine window.
|
|
|
|
if (mine.getOwningGuild().getNation().getMineTime() ==
|
|
LocalDateTime.now().getHour() && mine.wasClaimed == false) {
|
|
HourlyJobThread.mineWindowOpen(mine);
|
|
continue;
|
|
}
|
|
|
|
// Close the mine if it reaches this far
|
|
|
|
mineWindowClose(mine);
|
|
|
|
} catch (Exception e) {
|
|
Logger.error("mineID: " + mine.getObjectUUID(), e.toString());
|
|
}
|
|
}
|
|
} catch (Exception e) {
|
|
Logger.error(e.toString());
|
|
}
|
|
}
|
|
|
|
public static void mineWindowOpen(Mine mine) {
|
|
|
|
mine.setActive(true);
|
|
ChatManager.chatSystemChannel(mine.getZoneName() + "'s Mine is now Active!");
|
|
Logger.info(mine.getZoneName() + "'s Mine is now Active!");
|
|
}
|
|
|
|
public static boolean mineWindowClose(Mine mine) {
|
|
|
|
// No need to end the window of a mine which never opened.
|
|
|
|
if (mine.isActive == false)
|
|
return false;
|
|
|
|
Building mineBuilding = BuildingManager.getBuildingFromCache(mine.getBuildingID());
|
|
|
|
if (mineBuilding == null) {
|
|
Logger.debug("Null mine building for Mine " + mine.getObjectUUID() + " Building " + mine.getBuildingID());
|
|
return false;
|
|
}
|
|
|
|
// Mine building still stands; nothing to do.
|
|
// We can early exit here.
|
|
|
|
if (mineBuilding.getRank() > 0) {
|
|
mine.setActive(false);
|
|
mine.lastClaimer = null;
|
|
return true;
|
|
}
|
|
|
|
// This mine does not have a valid claimer
|
|
// we will therefore set it to errant
|
|
// and keep the window open.
|
|
|
|
if (!Mine.validateClaimer(mine.lastClaimer)) {
|
|
mine.lastClaimer = null;
|
|
mine.updateGuildOwner(null);
|
|
mine.setActive(true);
|
|
return false;
|
|
}
|
|
|
|
//Update ownership to map
|
|
|
|
mine.guildName = mine.getOwningGuild().getName();
|
|
mine.guildTag = mine.getOwningGuild().getGuildTag();
|
|
Guild nation = mine.getOwningGuild().getNation();
|
|
mine.nationName = nation.getName();
|
|
mine.nationTag = nation.getGuildTag();
|
|
|
|
BuildingManager.rebuildMine(mineBuilding);
|
|
WorldGrid.updateObject(mineBuilding);
|
|
|
|
ChatSystemMsg chatMsg = new ChatSystemMsg(null, mine.lastClaimer.getName() + " has claimed the mine in " + mine.getParentZone().parent.zoneName + " for " + mine.getOwningGuild().getName() + ". The mine is no longer active.");
|
|
chatMsg.setMessageType(10);
|
|
chatMsg.setChannel(mbEnums.ChatChannelType.SYSTEM.getChannelID());
|
|
DispatchManager.dispatchMsgToAll(chatMsg);
|
|
|
|
// Warehouse this claim event
|
|
|
|
MineRecord mineRecord = MineRecord.borrow(mine, mine.lastClaimer, mbEnums.RecordEventType.CAPTURE);
|
|
DataWarehouse.pushToWarehouse(mineRecord);
|
|
|
|
BuildingManager.setRank(mineBuilding, mineBuilding.getRank());
|
|
mine.lastClaimer = null;
|
|
mine.setActive(false);
|
|
mine.wasClaimed = true;
|
|
return true;
|
|
}
|
|
|
|
public void run() {
|
|
|
|
// *** REFACTOR: TRY TRY TRY TRY {{{{{{{{{{{ OMG
|
|
|
|
Logger.info("Hourly job is now running.");
|
|
|
|
try {
|
|
|
|
// Use the same hotZone this hour up and until
|
|
// the HotZone_Duration from the ConfigManager
|
|
|
|
if (ZoneManager.hotZone == null)
|
|
ZoneManager.generateAndSetRandomHotzone();
|
|
else
|
|
ZoneManager.hotZoneCycle = ZoneManager.hotZoneCycle + 1;
|
|
|
|
if (ZoneManager.hotZoneCycle > Integer.parseInt(ConfigManager.MB_HOTZONE_DURATION.getValue()))
|
|
ZoneManager.generateAndSetRandomHotzone();
|
|
|
|
if (ZoneManager.hotZone == null) {
|
|
Logger.error("Null HotZone returned from ZoneManager");
|
|
} else {
|
|
Logger.info("HotZone switched to: " + ZoneManager.hotZone.zoneName);
|
|
}
|
|
|
|
} catch (Exception e) {
|
|
Logger.error(e.toString());
|
|
}
|
|
|
|
// Open or Close mines for the current mine window.
|
|
|
|
processMineWindow();
|
|
|
|
// Deposit mine resources to Guilds
|
|
|
|
for (Mine mine : Mine.getMines()) {
|
|
|
|
try {
|
|
mine.depositMineResources();
|
|
} catch (Exception e) {
|
|
Logger.info(e.getMessage() + " for Mine " + mine.getObjectUUID());
|
|
}
|
|
}
|
|
|
|
// Reset time-gated access to WOO slider.
|
|
// *** Do this after the mines open/close!
|
|
|
|
if (LocalDateTime.now().getHour() == MINE_LATE_WINDOW) {
|
|
Guild guild;
|
|
|
|
for (AbstractGameObject dbObject : DbManager.getList(mbEnums.GameObjectType.Guild)) {
|
|
guild = (Guild) dbObject;
|
|
|
|
if (guild != null)
|
|
guild.wooWasModified = false;
|
|
}
|
|
}
|
|
|
|
// Mines can only be claimed once per cycle.
|
|
// This will reset at 1am after the last mine
|
|
// window closes.
|
|
|
|
if (LocalDateTime.now().getHour() == MINE_LATE_WINDOW + 1) {
|
|
|
|
for (Mine mine : Mine.getMines()) {
|
|
|
|
if (mine.wasClaimed == true)
|
|
mine.wasClaimed = false;
|
|
}
|
|
}
|
|
|
|
// Decay Shrines at midnight every day
|
|
|
|
if (LocalDateTime.now().getHour() == MINE_LATE_WINDOW)
|
|
decayShrines();
|
|
|
|
// Update city population values
|
|
|
|
ConcurrentHashMap<Integer, AbstractGameObject> map = DbManager.getMap(mbEnums.GameObjectType.City);
|
|
|
|
if (map != null) {
|
|
|
|
for (AbstractGameObject ago : map.values()) {
|
|
|
|
City city = (City) ago;
|
|
|
|
if (city != null)
|
|
if (city.getGuild() != null) {
|
|
ArrayList<PlayerCharacter> guildList = Guild.GuildRoster(city.getGuild());
|
|
city.setPopulation(guildList.size());
|
|
}
|
|
}
|
|
City.lastCityUpdate = System.currentTimeMillis();
|
|
} else {
|
|
Logger.error("missing city map");
|
|
}
|
|
|
|
processBanes();
|
|
|
|
// Log metrics to console
|
|
Logger.info(WorldServer.getUptimeString());
|
|
Logger.info(SimulationManager.getPopulationString());
|
|
Logger.info(MessageDispatcher.getNetstatString());
|
|
Logger.info(PurgeOprhans.recordsDeleted.toString() + "orphaned items deleted");
|
|
}
|
|
|
|
public static void processBanes(){
|
|
//handle banes
|
|
for(Bane bane : Bane.banes.values()){
|
|
if(bane.getLiveDate() != null && DateTime.now().isAfter(bane.getLiveDate().minusMinutes(1)) && bane.isStarted == false)
|
|
bane.startBane();
|
|
}
|
|
}
|
|
}
|