@ -10,179 +10,20 @@
package engine.workthreads ; package engine.workthreads ;
import engine.Enum ; import engine.Enum ;
import engine.InterestManagement.WorldGrid ;
import engine.db.archive.DataWarehouse ;
import engine.db.archive.MineRecord ;
import engine.gameManager.* ; import engine.gameManager.* ;
import engine.net.DispatchMessage ;
import engine.net.MessageDispatcher ; import engine.net.MessageDispatcher ;
import engine.net.client.msg.chat.ChatSystemMsg ;
import engine.objects.* ; import engine.objects.* ;
import engine.server.world.WorldServer ; import engine.server.world.WorldServer ;
import org.pmw.tinylog.Logger ; import org.pmw.tinylog.Logger ;
import java.time.LocalDateTime ;
import java.util.ArrayList ; import java.util.ArrayList ;
import java.util.concurrent.ConcurrentHashMap ; import java.util.concurrent.ConcurrentHashMap ;
import static engine.server.MBServerStatics.MINE_LATE_WINDOW ;
public class HourlyJobThread implements Runnable { public class HourlyJobThread implements Runnable {
public HourlyJobThread ( ) { public HourlyJobThread ( ) {
} }
public static void decayShrines ( ) {
ArrayList < Shrine > shrineList = new ArrayList < > ( ) ;
for ( Shrine shrine : Shrine . shrinesByBuildingUUID . values ( ) ) {
try {
Building shrineBuilding = ( Building ) DbManager . getObject ( Enum . 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 ( ) ;
mineBuilding . rebuildMine ( ) ;
WorldGrid . updateObject ( mineBuilding ) ;
ChatSystemMsg chatMsg = new ChatSystemMsg ( null , mine . lastClaimer . getName ( ) + " has claimed the mine in " + mine . getParentZone ( ) . getParent ( ) . getName ( ) + " for " + mine . getOwningGuild ( ) . getName ( ) + ". The mine is no longer active." ) ;
chatMsg . setMessageType ( 10 ) ;
chatMsg . setChannel ( Enum . ChatChannelType . SYSTEM . getChannelID ( ) ) ;
DispatchMessage . dispatchMsgToAll ( chatMsg ) ;
// Warehouse this claim event
MineRecord mineRecord = MineRecord . borrow ( mine , mine . lastClaimer , Enum . RecordEventType . CAPTURE ) ;
DataWarehouse . pushToWarehouse ( mineRecord ) ;
mineBuilding . setRank ( mineBuilding . getRank ( ) ) ;
mine . lastClaimer = null ;
mine . setActive ( false ) ;
mine . wasClaimed = true ;
return true ;
}
public void run ( ) { public void run ( ) {
// *** REFACTOR: TRY TRY TRY TRY {{{{{{{{{{{ OMG
// *** REFACTOR: TRY TRY TRY TRY {{{{{{{{{{{ OMG
