640 lines
No EOL
18 KiB
C#
640 lines
No EOL
18 KiB
C#
using System;
|
|
using System.IO;
|
|
using System.Text;
|
|
using System.Collections;
|
|
using System.Collections.Generic;
|
|
using Server;
|
|
using Server.Misc;
|
|
using Server.Items;
|
|
using Server.Guilds;
|
|
using Server.Mobiles;
|
|
using Server.Accounting;
|
|
using Server.Commands;
|
|
|
|
namespace Server.Engines.MyRunUO
|
|
{
|
|
public class MyRunUO : Timer
|
|
{
|
|
private static double CpuInterval = 0.1; // Processor runs every 0.1 seconds
|
|
private static double CpuPercent = 0.25; // Processor runs for 25% of Interval, or ~25ms. This should take around 25% cpu
|
|
|
|
public static void Initialize()
|
|
{
|
|
if ( Config.Enabled )
|
|
{
|
|
Timer.DelayCall( TimeSpan.FromSeconds( 10.0 ), Config.CharacterUpdateInterval, new TimerCallback( Begin ) );
|
|
|
|
CommandSystem.Register( "UpdateMyRunUO", AccessLevel.Administrator, new CommandEventHandler( UpdateMyRunUO_OnCommand ) );
|
|
|
|
CommandSystem.Register( "PublicChar", AccessLevel.Player, new CommandEventHandler( PublicChar_OnCommand ) );
|
|
CommandSystem.Register( "PrivateChar", AccessLevel.Player, new CommandEventHandler( PrivateChar_OnCommand ) );
|
|
}
|
|
}
|
|
|
|
[Usage( "PublicChar" )]
|
|
[Description( "Enables showing extended character stats and skills in MyRunUO." )]
|
|
public static void PublicChar_OnCommand( CommandEventArgs e )
|
|
{
|
|
PlayerMobile pm = e.Mobile as PlayerMobile;
|
|
|
|
if ( pm != null )
|
|
{
|
|
if ( pm.PublicMyRunUO )
|
|
{
|
|
pm.SendMessage( "You have already chosen to show your skills and stats." );
|
|
}
|
|
else
|
|
{
|
|
pm.PublicMyRunUO = true;
|
|
pm.SendMessage( "All of your skills and stats will now be shown publicly in MyRunUO." );
|
|
}
|
|
}
|
|
}
|
|
|
|
[Usage( "PublicChar" )]
|
|
[Description( "Disables showing extended character stats and skills in MyRunUO." )]
|
|
public static void PrivateChar_OnCommand( CommandEventArgs e )
|
|
{
|
|
PlayerMobile pm = e.Mobile as PlayerMobile;
|
|
|
|
if ( pm != null )
|
|
{
|
|
if ( !pm.PublicMyRunUO )
|
|
{
|
|
pm.SendMessage( "You have already chosen to not show your skills and stats." );
|
|
}
|
|
else
|
|
{
|
|
pm.PublicMyRunUO = false;
|
|
pm.SendMessage( "Only a general level of your top three skills will be shown in MyRunUO." );
|
|
}
|
|
}
|
|
}
|
|
|
|
[Usage( "UpdateMyRunUO" )]
|
|
[Description( "Starts the process of updating the MyRunUO character and guild database." )]
|
|
public static void UpdateMyRunUO_OnCommand( CommandEventArgs e )
|
|
{
|
|
if ( m_Command != null && m_Command.HasCompleted )
|
|
m_Command = null;
|
|
|
|
if ( m_Timer == null && m_Command == null )
|
|
{
|
|
Begin();
|
|
e.Mobile.SendMessage( "MyRunUO update process has been started." );
|
|
}
|
|
else
|
|
{
|
|
e.Mobile.SendMessage( "MyRunUO database is already being updated." );
|
|
}
|
|
}
|
|
|
|
public static void Begin()
|
|
{
|
|
if ( m_Command != null && m_Command.HasCompleted )
|
|
m_Command = null;
|
|
|
|
if ( m_Timer != null || m_Command != null )
|
|
return;
|
|
|
|
m_Timer = new MyRunUO();
|
|
m_Timer.Start();
|
|
}
|
|
|
|
private static Timer m_Timer;
|
|
|
|
private Stage m_Stage;
|
|
private ArrayList m_List;
|
|
private List<IAccount> m_Collecting;
|
|
private int m_Index;
|
|
|
|
private static DatabaseCommandQueue m_Command;
|
|
|
|
private string m_SkillsPath;
|
|
private string m_LayersPath;
|
|
private string m_MobilesPath;
|
|
|
|
private StreamWriter m_OpSkills;
|
|
private StreamWriter m_OpLayers;
|
|
private StreamWriter m_OpMobiles;
|
|
|
|
private DateTime m_StartTime;
|
|
|
|
public MyRunUO() : base( TimeSpan.FromSeconds( CpuInterval ), TimeSpan.FromSeconds( CpuInterval ) )
|
|
{
|
|
m_List = new ArrayList();
|
|
m_Collecting = new List<IAccount>();
|
|
|
|
m_StartTime = DateTime.Now;
|
|
Console.WriteLine( "MyRunUO: Updating character database" );
|
|
}
|
|
|
|
protected override void OnTick()
|
|
{
|
|
bool shouldExit = false;
|
|
|
|
try
|
|
{
|
|
shouldExit = Process( DateTime.Now + TimeSpan.FromSeconds( CpuInterval * CpuPercent ) );
|
|
|
|
if ( shouldExit )
|
|
Console.WriteLine( "MyRunUO: Database statements compiled in {0:F2} seconds", (DateTime.Now - m_StartTime).TotalSeconds );
|
|
}
|
|
catch ( Exception e )
|
|
{
|
|
Console.WriteLine( "MyRunUO: {0}: Exception cought while processing", m_Stage );
|
|
Console.WriteLine( e );
|
|
shouldExit = true;
|
|
}
|
|
|
|
if ( shouldExit )
|
|
{
|
|
m_Command.Enqueue( null );
|
|
|
|
Stop();
|
|
m_Timer = null;
|
|
}
|
|
}
|
|
|
|
private enum Stage
|
|
{
|
|
CollectingMobiles,
|
|
DumpingMobiles,
|
|
CollectingGuilds,
|
|
DumpingGuilds,
|
|
Complete
|
|
}
|
|
|
|
public bool Process( DateTime endTime )
|
|
{
|
|
switch ( m_Stage )
|
|
{
|
|
case Stage.CollectingMobiles: CollectMobiles( endTime ); break;
|
|
case Stage.DumpingMobiles: DumpMobiles( endTime ); break;
|
|
case Stage.CollectingGuilds: CollectGuilds( endTime ); break;
|
|
case Stage.DumpingGuilds: DumpGuilds( endTime ); break;
|
|
}
|
|
|
|
return ( m_Stage == Stage.Complete );
|
|
}
|
|
|
|
private static ArrayList m_MobilesToUpdate = new ArrayList();
|
|
|
|
public static void QueueMobileUpdate( Mobile m )
|
|
{
|
|
if ( !Config.Enabled || Config.LoadDataInFile )
|
|
return;
|
|
|
|
m_MobilesToUpdate.Add( m );
|
|
}
|
|
|
|
public void CollectMobiles( DateTime endTime )
|
|
{
|
|
if ( Config.LoadDataInFile )
|
|
{
|
|
if ( m_Index == 0 )
|
|
m_Collecting.AddRange( Accounts.GetAccounts() );
|
|
|
|
for ( int i = m_Index; i < m_Collecting.Count; ++i )
|
|
{
|
|
IAccount acct = m_Collecting[i];
|
|
|
|
for ( int j = 0; j < acct.Length; ++j )
|
|
{
|
|
Mobile mob = acct[j];
|
|
|
|
if ( mob != null && mob.AccessLevel < Config.HiddenAccessLevel )
|
|
m_List.Add( mob );
|
|
}
|
|
|
|
++m_Index;
|
|
|
|
if ( DateTime.Now >= endTime )
|
|
break;
|
|
}
|
|
|
|
if ( m_Index == m_Collecting.Count )
|
|
{
|
|
m_Collecting = new List<IAccount>();
|
|
m_Stage = Stage.DumpingMobiles;
|
|
m_Index = 0;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
m_List = m_MobilesToUpdate;
|
|
m_MobilesToUpdate = new ArrayList();
|
|
m_Stage = Stage.DumpingMobiles;
|
|
m_Index = 0;
|
|
}
|
|
}
|
|
|
|
public void CheckConnection()
|
|
{
|
|
if ( m_Command == null )
|
|
{
|
|
m_Command = new DatabaseCommandQueue( "MyRunUO: Characeter database updated in {0:F1} seconds", "MyRunUO Character Database Thread" );
|
|
|
|
if ( Config.LoadDataInFile )
|
|
{
|
|
m_OpSkills = GetUniqueWriter( "skills", out m_SkillsPath );
|
|
m_OpLayers = GetUniqueWriter( "layers", out m_LayersPath );
|
|
m_OpMobiles = GetUniqueWriter( "mobiles", out m_MobilesPath );
|
|
|
|
m_Command.Enqueue( "TRUNCATE TABLE myrunuo_characters" );
|
|
m_Command.Enqueue( "TRUNCATE TABLE myrunuo_characters_layers" );
|
|
m_Command.Enqueue( "TRUNCATE TABLE myrunuo_characters_skills" );
|
|
}
|
|
|
|
m_Command.Enqueue( "TRUNCATE TABLE myrunuo_guilds" );
|
|
m_Command.Enqueue( "TRUNCATE TABLE myrunuo_guilds_wars" );
|
|
}
|
|
}
|
|
|
|
public void ExecuteNonQuery( string text )
|
|
{
|
|
m_Command.Enqueue( text );
|
|
}
|
|
|
|
public void ExecuteNonQuery( string format, params string[] args )
|
|
{
|
|
ExecuteNonQuery( String.Format( format, args ) );
|
|
}
|
|
|
|
public void ExecuteNonQueryIfNull( string select, string insert )
|
|
{
|
|
m_Command.Enqueue( new string[]{ select, insert } );
|
|
}
|
|
|
|
private void AppendCharEntity( string input, int charIndex, ref StringBuilder sb, char c )
|
|
{
|
|
if ( sb == null )
|
|
{
|
|
if ( charIndex > 0 )
|
|
sb = new StringBuilder( input, 0, charIndex, input.Length + 20 );
|
|
else
|
|
sb = new StringBuilder( input.Length + 20 );
|
|
}
|
|
|
|
sb.Append( "&#" );
|
|
sb.Append( (int)c );
|
|
sb.Append( ";" );
|
|
}
|
|
|
|
private void AppendEntityRef( string input, int charIndex, ref StringBuilder sb, string ent )
|
|
{
|
|
if ( sb == null )
|
|
{
|
|
if ( charIndex > 0 )
|
|
sb = new StringBuilder( input, 0, charIndex, input.Length + 20 );
|
|
else
|
|
sb = new StringBuilder( input.Length + 20 );
|
|
}
|
|
|
|
sb.Append( ent );
|
|
}
|
|
|
|
private string SafeString( string input )
|
|
{
|
|
if ( input == null )
|
|
return "";
|
|
|
|
StringBuilder sb = null;
|
|
|
|
for ( int i = 0; i < input.Length; ++i )
|
|
{
|
|
char c = input[i];
|
|
|
|
if ( c < 0x20 || c > 0x80 )
|
|
{
|
|
AppendCharEntity( input, i, ref sb, c );
|
|
}
|
|
else
|
|
{
|
|
switch ( c )
|
|
{
|
|
case '&': AppendEntityRef( input, i, ref sb, "&" ); break;
|
|
case '>': AppendEntityRef( input, i, ref sb, ">" ); break;
|
|
case '<': AppendEntityRef( input, i, ref sb, "<" ); break;
|
|
case '"': AppendEntityRef( input, i, ref sb, """ ); break;
|
|
case '\'':
|
|
case ':':
|
|
case '/':
|
|
case '\\': AppendCharEntity( input, i, ref sb, c ); break;
|
|
default:
|
|
{
|
|
if ( sb != null )
|
|
sb.Append( c );
|
|
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
if ( sb != null )
|
|
return sb.ToString();
|
|
|
|
return input;
|
|
}
|
|
|
|
public const char LineStart = '\"';
|
|
public const string EntrySep = "\",\"";
|
|
public const string LineEnd = "\"\n";
|
|
|
|
public void InsertMobile( Mobile mob )
|
|
{
|
|
string guildTitle = mob.GuildTitle;
|
|
|
|
if ( guildTitle == null || (guildTitle = guildTitle.Trim()).Length == 0 )
|
|
guildTitle = "NULL";
|
|
else
|
|
guildTitle = SafeString( guildTitle );
|
|
|
|
string notoTitle = SafeString( Titles.ComputeTitle( null, mob ) );
|
|
string female = ( mob.Female ? "1" : "0" );
|
|
|
|
bool pubBool = ( mob is PlayerMobile ) && ( ((PlayerMobile)mob).PublicMyRunUO );
|
|
|
|
string pubString = ( pubBool ? "1" : "0" );
|
|
|
|
string guildId = ( mob.Guild == null ? "NULL" : mob.Guild.Id.ToString() );
|
|
|
|
if ( Config.LoadDataInFile )
|
|
{
|
|
m_OpMobiles.Write( LineStart );
|
|
m_OpMobiles.Write( mob.Serial.Value );
|
|
m_OpMobiles.Write( EntrySep );
|
|
m_OpMobiles.Write( SafeString( mob.Name ) );
|
|
m_OpMobiles.Write( EntrySep );
|
|
m_OpMobiles.Write( mob.RawStr );
|
|
m_OpMobiles.Write( EntrySep );
|
|
m_OpMobiles.Write( mob.RawDex );
|
|
m_OpMobiles.Write( EntrySep );
|
|
m_OpMobiles.Write( mob.RawInt );
|
|
m_OpMobiles.Write( EntrySep );
|
|
m_OpMobiles.Write( female );
|
|
m_OpMobiles.Write( EntrySep );
|
|
m_OpMobiles.Write( mob.Kills );
|
|
m_OpMobiles.Write( EntrySep );
|
|
m_OpMobiles.Write( guildId );
|
|
m_OpMobiles.Write( EntrySep );
|
|
m_OpMobiles.Write( guildTitle );
|
|
m_OpMobiles.Write( EntrySep );
|
|
m_OpMobiles.Write( notoTitle );
|
|
m_OpMobiles.Write( EntrySep );
|
|
m_OpMobiles.Write( mob.Hue );
|
|
m_OpMobiles.Write( EntrySep );
|
|
m_OpMobiles.Write( pubString );
|
|
m_OpMobiles.Write( LineEnd );
|
|
}
|
|
else
|
|
{
|
|
ExecuteNonQuery( "INSERT INTO myrunuo_characters (char_id, char_name, char_str, char_dex, char_int, char_female, char_counts, char_guild, char_guildtitle, char_nototitle, char_bodyhue, char_public ) VALUES ({0}, '{1}', {2}, {3}, {4}, {5}, {6}, {7}, {8}, '{9}', {10}, {11})", mob.Serial.Value.ToString(), SafeString( mob.Name ), mob.RawStr.ToString(), mob.RawDex.ToString(), mob.RawInt.ToString(), female, mob.Kills.ToString(), guildId, guildTitle, notoTitle, mob.Hue.ToString(), pubString );
|
|
}
|
|
}
|
|
|
|
public void InsertSkills( Mobile mob )
|
|
{
|
|
Skills skills = mob.Skills;
|
|
string serial = mob.Serial.Value.ToString();
|
|
|
|
for ( int i = 0; i < skills.Length; ++i )
|
|
{
|
|
Skill skill = skills[i];
|
|
|
|
if ( skill.BaseFixedPoint > 0 )
|
|
{
|
|
if ( Config.LoadDataInFile )
|
|
{
|
|
m_OpSkills.Write( LineStart );
|
|
m_OpSkills.Write( serial );
|
|
m_OpSkills.Write( EntrySep );
|
|
m_OpSkills.Write( i );
|
|
m_OpSkills.Write( EntrySep );
|
|
m_OpSkills.Write( skill.BaseFixedPoint );
|
|
m_OpSkills.Write( LineEnd );
|
|
}
|
|
else
|
|
{
|
|
ExecuteNonQuery( "INSERT INTO myrunuo_characters_skills (char_id, skill_id, skill_value) VALUES ({0}, {1}, {2})", serial, i.ToString(), skill.BaseFixedPoint.ToString() );
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
private ArrayList m_Items = new ArrayList();
|
|
|
|
private void InsertItem( string serial, int index, int itemID, int hue )
|
|
{
|
|
if ( Config.LoadDataInFile )
|
|
{
|
|
m_OpLayers.Write( LineStart );
|
|
m_OpLayers.Write( serial );
|
|
m_OpLayers.Write( EntrySep );
|
|
m_OpLayers.Write( index );
|
|
m_OpLayers.Write( EntrySep );
|
|
m_OpLayers.Write( itemID );
|
|
m_OpLayers.Write( EntrySep );
|
|
m_OpLayers.Write( hue );
|
|
m_OpLayers.Write( LineEnd );
|
|
}
|
|
else
|
|
{
|
|
ExecuteNonQuery( "INSERT INTO myrunuo_characters_layers (char_id, layer_id, item_id, item_hue) VALUES ({0}, {1}, {2}, {3})", serial, index.ToString(), itemID.ToString(), hue.ToString() );
|
|
}
|
|
}
|
|
|
|
public void InsertItems( Mobile mob )
|
|
{
|
|
ArrayList items = m_Items;
|
|
items.AddRange( mob.Items );
|
|
string serial = mob.Serial.Value.ToString();
|
|
|
|
items.Sort( LayerComparer.Instance );
|
|
|
|
int index = 0;
|
|
|
|
bool hidePants = false;
|
|
bool alive = mob.Alive;
|
|
bool hideHair = !alive;
|
|
|
|
for ( int i = 0; i < items.Count; ++i )
|
|
{
|
|
Item item = (Item)items[i];
|
|
|
|
if ( !LayerComparer.IsValid( item ) )
|
|
break;
|
|
|
|
if ( !alive && item.ItemID != 8270 )
|
|
continue;
|
|
|
|
if ( item.ItemID == 0x1411 || item.ItemID == 0x141A ) // plate legs
|
|
hidePants = true;
|
|
else if ( hidePants && item.Layer == Layer.Pants )
|
|
continue;
|
|
|
|
if ( !hideHair && item.Layer == Layer.Helm )
|
|
hideHair = true;
|
|
|
|
InsertItem( serial, index++, item.ItemID, item.Hue );
|
|
}
|
|
|
|
if ( mob.FacialHairItemID != 0 && alive )
|
|
InsertItem( serial, index++, mob.FacialHairItemID, mob.FacialHairHue );
|
|
|
|
if ( mob.HairItemID != 0 && !hideHair )
|
|
InsertItem( serial, index++, mob.HairItemID, mob.HairHue );
|
|
|
|
items.Clear();
|
|
}
|
|
|
|
public void DeleteMobile( Mobile mob )
|
|
{
|
|
ExecuteNonQuery( "DELETE FROM myrunuo_characters WHERE char_id = {0}", mob.Serial.Value.ToString() );
|
|
ExecuteNonQuery( "DELETE FROM myrunuo_characters_skills WHERE char_id = {0}", mob.Serial.Value.ToString() );
|
|
ExecuteNonQuery( "DELETE FROM myrunuo_characters_layers WHERE char_id = {0}", mob.Serial.Value.ToString() );
|
|
}
|
|
|
|
public StreamWriter GetUniqueWriter( string type, out string filePath )
|
|
{
|
|
filePath = Path.Combine( Core.BaseDirectory, String.Format( "myrunuodb_{0}.txt", type ) ).Replace( Path.DirectorySeparatorChar, Path.AltDirectorySeparatorChar );
|
|
|
|
try
|
|
{
|
|
return new StreamWriter( filePath );
|
|
}
|
|
catch
|
|
{
|
|
for ( int i = 0; i < 100; ++i )
|
|
{
|
|
try
|
|
{
|
|
filePath = Path.Combine( Core.BaseDirectory, String.Format( "myrunuodb_{0}_{1}.txt", type, i ) ).Replace( Path.DirectorySeparatorChar, Path.AltDirectorySeparatorChar );
|
|
return new StreamWriter( filePath );
|
|
}
|
|
catch
|
|
{
|
|
}
|
|
}
|
|
}
|
|
|
|
return null;
|
|
}
|
|
|
|
public void DumpMobiles( DateTime endTime )
|
|
{
|
|
CheckConnection();
|
|
|
|
for ( int i = m_Index; i < m_List.Count; ++i )
|
|
{
|
|
Mobile mob = (Mobile)m_List[i];
|
|
|
|
if ( mob is PlayerMobile )
|
|
((PlayerMobile)mob).ChangedMyRunUO = false;
|
|
|
|
if ( !mob.Deleted && mob.AccessLevel < Config.HiddenAccessLevel )
|
|
{
|
|
if ( !Config.LoadDataInFile )
|
|
DeleteMobile( mob );
|
|
|
|
InsertMobile( mob );
|
|
InsertSkills( mob );
|
|
InsertItems( mob );
|
|
}
|
|
else if ( !Config.LoadDataInFile )
|
|
{
|
|
DeleteMobile( mob );
|
|
}
|
|
|
|
++m_Index;
|
|
|
|
if ( DateTime.Now >= endTime )
|
|
break;
|
|
}
|
|
|
|
if ( m_Index == m_List.Count )
|
|
{
|
|
m_List.Clear();
|
|
m_Stage = Stage.CollectingGuilds;
|
|
m_Index = 0;
|
|
|
|
if ( Config.LoadDataInFile )
|
|
{
|
|
m_OpSkills.Close();
|
|
m_OpLayers.Close();
|
|
m_OpMobiles.Close();
|
|
|
|
ExecuteNonQuery( "LOAD DATA {0}INFILE '{1}' INTO TABLE myrunuo_characters FIELDS TERMINATED BY ',' ENCLOSED BY '\"' LINES TERMINATED BY '\n'", Config.DatabaseNonLocal ? "LOCAL " : "", m_MobilesPath );
|
|
ExecuteNonQuery( "LOAD DATA {0}INFILE '{1}' INTO TABLE myrunuo_characters_skills FIELDS TERMINATED BY ',' ENCLOSED BY '\"' LINES TERMINATED BY '\n'", Config.DatabaseNonLocal ? "LOCAL " : "", m_SkillsPath );
|
|
ExecuteNonQuery( "LOAD DATA {0}INFILE '{1}' INTO TABLE myrunuo_characters_layers FIELDS TERMINATED BY ',' ENCLOSED BY '\"' LINES TERMINATED BY '\n'", Config.DatabaseNonLocal ? "LOCAL " : "", m_LayersPath );
|
|
}
|
|
}
|
|
}
|
|
|
|
public void CollectGuilds( DateTime endTime )
|
|
{
|
|
m_List.AddRange( Guild.List.Values );
|
|
m_Stage = Stage.DumpingGuilds;
|
|
m_Index = 0;
|
|
}
|
|
|
|
public void InsertGuild( Guild guild )
|
|
{
|
|
string guildType = "Standard";
|
|
|
|
switch ( guild.Type )
|
|
{
|
|
case GuildType.Chaos: guildType = "Chaos"; break;
|
|
case GuildType.Order: guildType = "Order"; break;
|
|
}
|
|
|
|
ExecuteNonQuery( "INSERT INTO myrunuo_guilds (guild_id, guild_name, guild_abbreviation, guild_website, guild_charter, guild_type, guild_wars, guild_members, guild_master) VALUES ({0}, '{1}', {2}, {3}, {4}, '{5}', {6}, {7}, {8})", guild.Id.ToString(), SafeString( guild.Name ), guild.Abbreviation == "none" ? "NULL" : "'" + SafeString( guild.Abbreviation ) + "'", guild.Website == null ? "NULL" : "'" + SafeString( guild.Website ) + "'", guild.Charter == null ? "NULL" : "'" + SafeString( guild.Charter ) + "'", guildType, guild.Enemies.Count.ToString(), guild.Members.Count.ToString(), guild.Leader.Serial.Value.ToString() );
|
|
}
|
|
|
|
public void InsertWars( Guild guild )
|
|
{
|
|
List<Guild> wars = guild.Enemies;
|
|
|
|
string ourId = guild.Id.ToString();
|
|
|
|
for ( int i = 0; i < wars.Count; ++i )
|
|
{
|
|
Guild them = wars[i];
|
|
string theirId = them.Id.ToString();
|
|
|
|
ExecuteNonQueryIfNull(
|
|
String.Format( "SELECT guild_1 FROM myrunuo_guilds_wars WHERE (guild_1={0} AND guild_2={1}) OR (guild_1={1} AND guild_2={0})", ourId, theirId ),
|
|
String.Format( "INSERT INTO myrunuo_guilds_wars (guild_1, guild_2) VALUES ({0}, {1})", ourId, theirId ) );
|
|
}
|
|
}
|
|
|
|
public void DumpGuilds( DateTime endTime )
|
|
{
|
|
CheckConnection();
|
|
|
|
for ( int i = m_Index; i < m_List.Count; ++i )
|
|
{
|
|
Guild guild = (Guild)m_List[i];
|
|
|
|
if ( !guild.Disbanded )
|
|
{
|
|
InsertGuild( guild );
|
|
InsertWars( guild );
|
|
}
|
|
|
|
++m_Index;
|
|
|
|
if ( DateTime.Now >= endTime )
|
|
break;
|
|
}
|
|
|
|
if ( m_Index == m_List.Count )
|
|
{
|
|
m_List.Clear();
|
|
m_Stage = Stage.Complete;
|
|
m_Index = 0;
|
|
}
|
|
}
|
|
}
|
|
} |