TerritoryWarManager.java 50 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585
  1. /*
  2. * This program is free software: you can redistribute it and/or modify it under
  3. * the terms of the GNU General Public License as published by the Free Software
  4. * Foundation, either version 3 of the License, or (at your option) any later
  5. * version.
  6. *
  7. * This program is distributed in the hope that it will be useful, but WITHOUT
  8. * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
  9. * FOR A PARTICULAR PURPOSE. See the GNU General Public License for more
  10. * details.
  11. *
  12. * You should have received a copy of the GNU General Public License along with
  13. * this program. If not, see <http://www.gnu.org/licenses/>.
  14. */
  15. package com.l2jserver.gameserver.instancemanager;
  16. import java.io.File;
  17. import java.io.FileInputStream;
  18. import java.io.IOException;
  19. import java.io.InputStream;
  20. import java.sql.Connection;
  21. import java.sql.PreparedStatement;
  22. import java.sql.ResultSet;
  23. import java.util.Calendar;
  24. import java.util.Collection;
  25. import java.util.List;
  26. import java.util.Map;
  27. import java.util.concurrent.ScheduledFuture;
  28. import java.util.logging.Level;
  29. import java.util.logging.Logger;
  30. import javolution.util.FastList;
  31. import javolution.util.FastMap;
  32. import com.l2jserver.Config;
  33. import com.l2jserver.L2DatabaseFactory;
  34. import com.l2jserver.gameserver.Announcements;
  35. import com.l2jserver.gameserver.ThreadPoolManager;
  36. import com.l2jserver.gameserver.datatables.ClanTable;
  37. import com.l2jserver.gameserver.datatables.NpcTable;
  38. import com.l2jserver.gameserver.datatables.SkillTable;
  39. import com.l2jserver.gameserver.datatables.SkillTreesData;
  40. import com.l2jserver.gameserver.model.L2Clan;
  41. import com.l2jserver.gameserver.model.L2SiegeClan;
  42. import com.l2jserver.gameserver.model.L2SkillLearn;
  43. import com.l2jserver.gameserver.model.L2Spawn;
  44. import com.l2jserver.gameserver.model.L2World;
  45. import com.l2jserver.gameserver.model.Location;
  46. import com.l2jserver.gameserver.model.TerritoryWard;
  47. import com.l2jserver.gameserver.model.actor.L2Npc;
  48. import com.l2jserver.gameserver.model.actor.instance.L2DoorInstance;
  49. import com.l2jserver.gameserver.model.actor.instance.L2PcInstance;
  50. import com.l2jserver.gameserver.model.actor.instance.L2SiegeFlagInstance;
  51. import com.l2jserver.gameserver.model.actor.templates.L2NpcTemplate;
  52. import com.l2jserver.gameserver.model.entity.Castle;
  53. import com.l2jserver.gameserver.model.entity.Fort;
  54. import com.l2jserver.gameserver.model.entity.Siegable;
  55. import com.l2jserver.gameserver.model.quest.Quest;
  56. import com.l2jserver.gameserver.model.skills.L2Skill;
  57. import com.l2jserver.gameserver.network.SystemMessageId;
  58. import com.l2jserver.gameserver.network.serverpackets.L2GameServerPacket;
  59. import com.l2jserver.gameserver.network.serverpackets.SystemMessage;
  60. import com.l2jserver.gameserver.util.Util;
  61. import com.l2jserver.util.L2Properties;
  62. public class TerritoryWarManager implements Siegable
  63. {
  64. private static final Logger _log = Logger.getLogger(TerritoryWarManager.class.getName());
  65. // SQL
  66. private static final String DELETE = "DELETE FROM territory_registrations WHERE castleId = ? and registeredId = ?";
  67. private static final String INSERT = "INSERT INTO territory_registrations (castleId, registeredId) values (?, ?)";
  68. public static final TerritoryWarManager getInstance()
  69. {
  70. return SingletonHolder._instance;
  71. }
  72. public static String qn = "TerritoryWarSuperClass";
  73. public static int DEFENDERMAXCLANS; // Max number of clans
  74. public static int DEFENDERMAXPLAYERS; // Max number of individual player
  75. public static int CLANMINLEVEL;
  76. public static int PLAYERMINLEVEL;
  77. public static int MINTWBADGEFORNOBLESS;
  78. public static int MINTWBADGEFORSTRIDERS;
  79. public static int MINTWBADGEFORBIGSTRIDER;
  80. public static Long WARLENGTH;
  81. public static boolean PLAYER_WITH_WARD_CAN_BE_KILLED_IN_PEACEZONE;
  82. public static boolean SPAWN_WARDS_WHEN_TW_IS_NOT_IN_PROGRESS;
  83. public static boolean RETURN_WARDS_WHEN_TW_STARTS;
  84. public final Map<Integer,Integer> TERRITORY_ITEM_IDS;
  85. // Territory War settings
  86. private FastMap<Integer, FastList<L2Clan>> _registeredClans;
  87. private FastMap<Integer, FastList<Integer>> _registeredMercenaries;
  88. private FastMap<Integer, Territory> _territoryList;
  89. protected FastList<Integer> _disguisedPlayers;
  90. private FastList<TerritoryWard> _territoryWards;
  91. private FastMap<L2Clan, L2SiegeFlagInstance> _clanFlags;
  92. private Map<Integer,Integer[]> _participantPoints = new FastMap<>();
  93. protected Calendar _startTWDate = Calendar.getInstance();
  94. protected boolean _isRegistrationOver = true;
  95. protected boolean _isTWChannelOpen = false;
  96. private boolean _isTWInProgress = false;
  97. protected ScheduledFuture<?> _scheduledStartTWTask = null;
  98. protected ScheduledFuture<?> _scheduledEndTWTask = null;
  99. protected ScheduledFuture<?> _scheduledRewardOnlineTask = null;
  100. protected TerritoryWarManager()
  101. {
  102. // init lists
  103. _registeredClans = new FastMap<>();
  104. _registeredMercenaries = new FastMap<>();
  105. _territoryList = new FastMap<>();
  106. _territoryWards = new FastList<>();
  107. _clanFlags = new FastMap<>();
  108. _disguisedPlayers = new FastList<>();
  109. TERRITORY_ITEM_IDS = new FastMap<>();
  110. // Constant data
  111. TERRITORY_ITEM_IDS.put(81, 13757);
  112. TERRITORY_ITEM_IDS.put(82, 13758);
  113. TERRITORY_ITEM_IDS.put(83, 13759);
  114. TERRITORY_ITEM_IDS.put(84, 13760);
  115. TERRITORY_ITEM_IDS.put(85, 13761);
  116. TERRITORY_ITEM_IDS.put(86, 13762);
  117. TERRITORY_ITEM_IDS.put(87, 13763);
  118. TERRITORY_ITEM_IDS.put(88, 13764);
  119. TERRITORY_ITEM_IDS.put(89, 13765);
  120. _registeredClans.shared();
  121. _registeredMercenaries.shared();
  122. _territoryList.shared();
  123. _territoryWards.shared();
  124. _clanFlags.shared();
  125. _disguisedPlayers.shared();
  126. // load data from database
  127. load();
  128. }
  129. public int getRegisteredTerritoryId(L2PcInstance player)
  130. {
  131. if (player == null || !_isTWChannelOpen || player.getLevel() < PLAYERMINLEVEL)
  132. return 0;
  133. if (player.getClan() != null)
  134. {
  135. if (player.getClan().getCastleId() > 0)
  136. return player.getClan().getCastleId() + 80;
  137. for(int cId:_registeredClans.keySet())
  138. if (_registeredClans.get(cId).contains(player.getClan()))
  139. return cId + 80;
  140. }
  141. for(int cId:_registeredMercenaries.keySet())
  142. if (_registeredMercenaries.get(cId).contains(player.getObjectId()))
  143. return cId + 80;
  144. return 0;
  145. }
  146. public boolean isAllyField(L2PcInstance player, int fieldId)
  147. {
  148. if (player == null || player.getSiegeSide() == 0)
  149. return false;
  150. else if ((player.getSiegeSide() - 80) == fieldId)
  151. return true;
  152. else if (fieldId > 100 && _territoryList.containsKey((player.getSiegeSide() - 80))
  153. && _territoryList.get((player.getSiegeSide() - 80)).getFortId() == fieldId)
  154. return true;
  155. return false;
  156. }
  157. /**
  158. * @param castleId
  159. * @param clan The L2Clan of the player
  160. * @return true if the clan is registered
  161. */
  162. public final boolean checkIsRegistered(int castleId, L2Clan clan)
  163. {
  164. if (clan == null)
  165. return false;
  166. if (clan.getCastleId() > 0)
  167. return (castleId == -1 ? true : (clan.getCastleId() == castleId));
  168. if (castleId == -1)
  169. {
  170. for(int cId:_registeredClans.keySet())
  171. if (_registeredClans.get(cId).contains(clan))
  172. return true;
  173. return false;
  174. }
  175. return _registeredClans.get(castleId).contains(clan);
  176. }
  177. /**
  178. * @param castleId
  179. * @param objId
  180. * @return true if the player is registered
  181. */
  182. public final boolean checkIsRegistered(int castleId, int objId)
  183. {
  184. if (castleId == -1)
  185. {
  186. for(int cId:_registeredMercenaries.keySet())
  187. if (_registeredMercenaries.get(cId).contains(objId))
  188. return true;
  189. return false;
  190. }
  191. return _registeredMercenaries.get(castleId).contains(objId);
  192. }
  193. public Territory getTerritory(int castleId)
  194. {
  195. return _territoryList.get(castleId);
  196. }
  197. public FastList<Territory> getAllTerritories()
  198. {
  199. FastList<Territory> ret = new FastList<>();
  200. for (Territory t : _territoryList.values())
  201. if (t.getOwnerClan() != null)
  202. ret.add(t);
  203. return ret;
  204. }
  205. public Collection<L2Clan> getRegisteredClans(int castleId)
  206. {
  207. return _registeredClans.get(castleId);
  208. }
  209. public void addDisguisedPlayer(int playerObjId)
  210. {
  211. _disguisedPlayers.add(playerObjId);
  212. }
  213. public boolean isDisguised(int playerObjId)
  214. {
  215. return _disguisedPlayers.contains(playerObjId);
  216. }
  217. public Collection<Integer> getRegisteredMercenaries(int castleId)
  218. {
  219. return _registeredMercenaries.get(castleId);
  220. }
  221. public long getTWStartTimeInMillis()
  222. {
  223. return _startTWDate.getTimeInMillis();
  224. }
  225. public Calendar getTWStart()
  226. {
  227. return _startTWDate;
  228. }
  229. public void setTWStartTimeInMillis(long time)
  230. {
  231. _startTWDate.setTimeInMillis(time);
  232. if (_isTWInProgress)
  233. {
  234. if (_scheduledEndTWTask != null)
  235. _scheduledEndTWTask.cancel(false);
  236. _scheduledEndTWTask = ThreadPoolManager.getInstance().scheduleGeneral(new ScheduleEndTWTask(), 1000);
  237. }
  238. else
  239. {
  240. if (_scheduledStartTWTask != null)
  241. _scheduledStartTWTask.cancel(false);
  242. _scheduledStartTWTask = ThreadPoolManager.getInstance().scheduleGeneral(new ScheduleStartTWTask(), 1000);
  243. }
  244. }
  245. public boolean isTWChannelOpen()
  246. {
  247. return _isTWChannelOpen;
  248. }
  249. public void registerClan(int castleId, L2Clan clan)
  250. {
  251. if (clan == null || (_registeredClans.get(castleId) != null && _registeredClans.get(castleId).contains(clan)))
  252. return;
  253. else if (_registeredClans.get(castleId) == null)
  254. _registeredClans.put(castleId, new FastList<L2Clan>());
  255. _registeredClans.get(castleId).add(clan);
  256. changeRegistration(castleId, clan.getClanId(), false);
  257. }
  258. public void registerMerc(int castleId, L2PcInstance player)
  259. {
  260. if (player == null || player.getLevel() < PLAYERMINLEVEL
  261. || (_registeredMercenaries.get(castleId) != null && _registeredMercenaries.get(castleId).contains(player.getObjectId())))
  262. return;
  263. else if (_registeredMercenaries.get(castleId) == null)
  264. _registeredMercenaries.put(castleId, new FastList<Integer>());
  265. _registeredMercenaries.get(castleId).add(player.getObjectId());
  266. changeRegistration(castleId, player.getObjectId(), false);
  267. }
  268. public void removeClan(int castleId, L2Clan clan)
  269. {
  270. if (clan == null)
  271. return;
  272. else if (_registeredClans.get(castleId) != null && _registeredClans.get(castleId).contains(clan))
  273. {
  274. _registeredClans.get(castleId).remove(clan);
  275. changeRegistration(castleId, clan.getClanId(), true);
  276. }
  277. }
  278. public void removeMerc(int castleId, L2PcInstance player)
  279. {
  280. if (player == null)
  281. return;
  282. else if (_registeredMercenaries.get(castleId) != null && _registeredMercenaries.get(castleId).contains(player.getObjectId()))
  283. {
  284. _registeredMercenaries.get(castleId).remove(_registeredMercenaries.get(castleId).indexOf(player.getObjectId()));
  285. changeRegistration(castleId, player.getObjectId(), true);
  286. }
  287. }
  288. public boolean getIsRegistrationOver()
  289. {
  290. return _isRegistrationOver;
  291. }
  292. public boolean isTWInProgress()
  293. {
  294. return _isTWInProgress;
  295. }
  296. public void territoryCatapultDestroyed(int castleId)
  297. {
  298. if (_territoryList.get(castleId) != null)
  299. _territoryList.get(castleId).changeNPCsSpawn(2, false);
  300. for (L2DoorInstance door : CastleManager.getInstance().getCastleById(castleId).getDoors())
  301. door.openMe();
  302. }
  303. public L2Npc addTerritoryWard(int territoryId, int newOwnerId, int oldOwnerId, boolean broadcastMessage)
  304. {
  305. L2Npc ret = null;
  306. if (_territoryList.get(newOwnerId) != null)
  307. {
  308. Territory terNew = _territoryList.get(newOwnerId);
  309. TerritoryNPCSpawn ward = terNew.getFreeWardSpawnPlace();
  310. if (ward != null)
  311. {
  312. ward._npcId = territoryId;
  313. ret = spawnNPC(36491 + territoryId, ward.getLocation());
  314. ward.setNPC(ret);
  315. if (!isTWInProgress() && !SPAWN_WARDS_WHEN_TW_IS_NOT_IN_PROGRESS)
  316. ret.decayMe();
  317. if (terNew.getOwnerClan() != null && terNew.getOwnedWardIds().contains(newOwnerId + 80))
  318. {
  319. for(int wardId : terNew.getOwnedWardIds())
  320. {
  321. final List<L2SkillLearn> residentialSkills = SkillTreesData.getInstance().getAvailableResidentialSkills(wardId);
  322. for (L2SkillLearn s : residentialSkills)
  323. {
  324. final L2Skill sk = SkillTable.getInstance().getInfo(s.getSkillId(), s.getSkillLevel());
  325. if (sk != null)
  326. {
  327. for (L2PcInstance member : terNew.getOwnerClan().getOnlineMembers(0))
  328. {
  329. if (!member.isInOlympiadMode())
  330. {
  331. member.addSkill(sk, false);
  332. }
  333. }
  334. }
  335. }
  336. }
  337. }
  338. }
  339. if (_territoryList.containsKey(oldOwnerId))
  340. {
  341. Territory terOld = _territoryList.get(oldOwnerId);
  342. terOld.removeWard(territoryId);
  343. updateTerritoryData(terOld);
  344. updateTerritoryData(terNew);
  345. if (broadcastMessage)
  346. {
  347. SystemMessage sm = SystemMessage.getSystemMessage(SystemMessageId.CLAN_S1_HAS_SUCCEDED_IN_CAPTURING_S2_TERRITORY_WARD);
  348. sm.addString(terNew.getOwnerClan().getName());
  349. sm.addCastleId(terNew.getTerritoryId());
  350. announceToParticipants(sm, 135000, 13500);
  351. }
  352. if (terOld.getOwnerClan() != null)
  353. {
  354. final List<L2SkillLearn> territorySkills = SkillTreesData.getInstance().getAvailableResidentialSkills(territoryId);
  355. for (L2SkillLearn s : territorySkills)
  356. {
  357. final L2Skill sk = SkillTable.getInstance().getInfo(s.getSkillId(), s.getSkillLevel());
  358. if (sk != null)
  359. {
  360. for (L2PcInstance member : terOld.getOwnerClan().getOnlineMembers(0))
  361. {
  362. member.removeSkill(sk, false);
  363. }
  364. }
  365. }
  366. if (!terOld.getOwnedWardIds().isEmpty() && !terOld.getOwnedWardIds().contains(oldOwnerId + 80))
  367. {
  368. for(int wardId : terOld.getOwnedWardIds())
  369. {
  370. final List<L2SkillLearn> wardSkills = SkillTreesData.getInstance().getAvailableResidentialSkills(wardId);
  371. for (L2SkillLearn s : wardSkills)
  372. {
  373. final L2Skill sk = SkillTable.getInstance().getInfo(s.getSkillId(), s.getSkillLevel());
  374. if (sk != null)
  375. {
  376. for (L2PcInstance member : terOld.getOwnerClan().getOnlineMembers(0))
  377. {
  378. member.removeSkill(sk, false);
  379. }
  380. }
  381. }
  382. }
  383. }
  384. }
  385. }
  386. }
  387. else
  388. _log.warning("TerritoryWarManager: Missing territory for new Ward owner: " + newOwnerId + ";" + territoryId);
  389. return ret;
  390. }
  391. public L2SiegeFlagInstance getHQForClan(L2Clan clan)
  392. {
  393. if (clan.getCastleId() > 0)
  394. return _territoryList.get(clan.getCastleId()).getHQ();
  395. return null;
  396. }
  397. public L2SiegeFlagInstance getHQForTerritory(int territoryId)
  398. {
  399. if (_territoryList.containsKey(territoryId - 80))
  400. return _territoryList.get(territoryId - 80).getHQ();
  401. return null;
  402. }
  403. public void setHQForClan(L2Clan clan, L2SiegeFlagInstance hq)
  404. {
  405. if (clan.getCastleId() > 0)
  406. _territoryList.get(clan.getCastleId()).setHQ(hq);
  407. }
  408. public void addClanFlag(L2Clan clan, L2SiegeFlagInstance flag)
  409. {
  410. _clanFlags.put(clan, flag);
  411. }
  412. public boolean isClanHasFlag(L2Clan clan)
  413. {
  414. return _clanFlags.containsKey(clan);
  415. }
  416. public L2SiegeFlagInstance getFlagForClan(L2Clan clan)
  417. {
  418. if (_clanFlags.containsKey(clan))
  419. return _clanFlags.get(clan);
  420. return null;
  421. }
  422. public void removeClanFlag(L2Clan clan)
  423. {
  424. _clanFlags.remove(clan);
  425. }
  426. public List<TerritoryWard> getAllTerritoryWards()
  427. {
  428. return _territoryWards;
  429. }
  430. public TerritoryWard getTerritoryWardForOwner(int castleId)
  431. {
  432. for(TerritoryWard twWard : _territoryWards)
  433. if (twWard.getTerritoryId() == castleId)
  434. return twWard;
  435. return null;
  436. }
  437. public TerritoryWard getTerritoryWard(int territoryId)
  438. {
  439. for(TerritoryWard twWard : _territoryWards)
  440. if (twWard.getTerritoryId() == territoryId)
  441. return twWard;
  442. return null;
  443. }
  444. public TerritoryWard getTerritoryWard(L2PcInstance player)
  445. {
  446. for(TerritoryWard twWard : _territoryWards)
  447. if (twWard.playerId == player.getObjectId())
  448. return twWard;
  449. return null;
  450. }
  451. public void dropCombatFlag(L2PcInstance player, boolean isKilled, boolean isSpawnBack)
  452. {
  453. for(TerritoryWard twWard : _territoryWards)
  454. if (twWard.playerId == player.getObjectId())
  455. {
  456. twWard.dropIt();
  457. if (isTWInProgress())
  458. {
  459. if (isKilled)
  460. twWard.spawnMe();
  461. else if (isSpawnBack)
  462. twWard.spawnBack();
  463. else
  464. for(TerritoryNPCSpawn wardSpawn : _territoryList.get(twWard.getOwnerCastleId()).getOwnedWard())
  465. if (wardSpawn.getNpcId() == twWard.getTerritoryId())
  466. {
  467. wardSpawn.setNPC(wardSpawn.getNpc().getSpawn().doSpawn());
  468. twWard.unSpawnMe();
  469. twWard.setNpc(wardSpawn.getNpc());
  470. }
  471. }
  472. if (isKilled)
  473. {
  474. SystemMessage sm = SystemMessage.getSystemMessage(SystemMessageId.THE_CHAR_THAT_ACQUIRED_S1_WARD_HAS_BEEN_KILLED);
  475. sm.addString(twWard.getNpc().getName().replaceAll(" Ward", ""));
  476. announceToParticipants(sm, 0, 0);
  477. }
  478. }
  479. }
  480. public void giveTWQuestPoint(L2PcInstance player)
  481. {
  482. if (!_participantPoints.containsKey(player.getObjectId()))
  483. _participantPoints.put(player.getObjectId(), new Integer[]{player.getSiegeSide(),0,0,0,0,0,0});
  484. _participantPoints.get(player.getObjectId())[2]++;
  485. }
  486. public void giveTWPoint(L2PcInstance killer, int victimSide, int type)
  487. {
  488. if (victimSide == 0)
  489. return;
  490. if (killer.getParty() != null && type < 5)
  491. for(L2PcInstance pl : killer.getParty().getMembers())
  492. {
  493. if (pl.getSiegeSide() == victimSide || pl.getSiegeSide() == 0 || !Util.checkIfInRange(2000, killer, pl, false))
  494. continue;
  495. else if (!_participantPoints.containsKey(pl.getObjectId()))
  496. _participantPoints.put(pl.getObjectId(), new Integer[]{pl.getSiegeSide(),0,0,0,0,0,0});
  497. _participantPoints.get(pl.getObjectId())[type]++;
  498. }
  499. else
  500. {
  501. if (killer.getSiegeSide() == victimSide || killer.getSiegeSide() == 0)
  502. return;
  503. else if (!_participantPoints.containsKey(killer.getObjectId()))
  504. _participantPoints.put(killer.getObjectId(), new Integer[]{killer.getSiegeSide(),0,0,0,0,0,0});
  505. _participantPoints.get(killer.getObjectId())[type]++;
  506. }
  507. }
  508. public int[] calcReward(L2PcInstance player)
  509. {
  510. if (_participantPoints.containsKey(player.getObjectId()))
  511. {
  512. int[] reward = new int[2];
  513. Integer[] temp = _participantPoints.get(player.getObjectId());
  514. reward[0] = temp[0];
  515. reward[1] = 0;
  516. // badges for being online. if char was not online at least 10 mins
  517. // than he cant get rewards(also this will handle that player already get his/her rewards)
  518. if (temp[6] < 10)
  519. return reward;
  520. reward[1] += (temp[6] > 70 ? 7 : (int)(temp[6] * 0.1));
  521. // badges for player Quests
  522. reward[1] += temp[2] * 7;
  523. // badges for player Kills
  524. if (temp[1] < 50)
  525. reward[1] += temp[1] * 0.1;
  526. else if (temp[1] < 120)
  527. reward[1] += (5 + (temp[1] - 50) / 14);
  528. else
  529. reward[1] += 10;
  530. // badges for territory npcs
  531. reward[1] += temp[3];
  532. // badges for territory catapults
  533. reward[1] += temp[4] * 2;
  534. // badges for territory Wards
  535. reward[1] += (temp[5] > 0 ? 5 : 0);
  536. // badges for territory quest done
  537. reward[1] += Math.min(_territoryList.get(temp[0] - 80).getQuestDone()[0], 10);
  538. reward[1] += _territoryList.get(temp[0] - 80).getQuestDone()[1];
  539. reward[1] += _territoryList.get(temp[0] - 80).getOwnedWardIds().size();
  540. return reward;
  541. }
  542. return new int[]{0,0};
  543. }
  544. public void debugReward(L2PcInstance player)
  545. {
  546. player.sendMessage("Registred TerrId: " + player.getSiegeSide());
  547. if (_participantPoints.containsKey(player.getObjectId()))
  548. {
  549. Integer[] temp = _participantPoints.get(player.getObjectId());
  550. player.sendMessage("TerrId: " + temp[0]);
  551. player.sendMessage("PcKill: " + temp[1]);
  552. player.sendMessage("PcQuests: " + temp[2]);
  553. player.sendMessage("npcKill: " + temp[3]);
  554. player.sendMessage("CatatKill: " + temp[4]);
  555. player.sendMessage("WardKill: " + temp[5]);
  556. player.sendMessage("onlineTime: " + temp[6]);
  557. }
  558. else
  559. player.sendMessage("No points for you!");
  560. if (_territoryList.containsKey(player.getSiegeSide() - 80))
  561. {
  562. player.sendMessage("Your Territory's jobs:");
  563. player.sendMessage("npcKill: " + _territoryList.get(player.getSiegeSide() - 80).getQuestDone()[0]);
  564. player.sendMessage("WardCaptured: " + _territoryList.get(player.getSiegeSide() - 80).getQuestDone()[1]);
  565. }
  566. }
  567. public void resetReward(L2PcInstance player)
  568. {
  569. if (_participantPoints.containsKey(player.getObjectId()))
  570. {
  571. _participantPoints.get(player.getObjectId())[6] = 0;
  572. }
  573. }
  574. public L2Npc spawnNPC(int npcId, Location loc)
  575. {
  576. L2NpcTemplate template = NpcTable.getInstance().getTemplate(npcId);
  577. if (template != null)
  578. {
  579. L2Spawn spawnDat;
  580. try
  581. {
  582. spawnDat = new L2Spawn(template);
  583. spawnDat.setAmount(1);
  584. spawnDat.setLocx(loc.getX());
  585. spawnDat.setLocy(loc.getY());
  586. spawnDat.setLocz(loc.getZ());
  587. spawnDat.setHeading(loc.getHeading());
  588. spawnDat.stopRespawn();
  589. return spawnDat.spawnOne(false);
  590. }
  591. catch (Exception e)
  592. {
  593. _log.log(Level.WARNING, "Territory War Manager: " + e.getMessage(), e);
  594. }
  595. }
  596. else
  597. {
  598. _log.warning("Territory War Manager: Data missing in NPC table for ID: " + npcId + ".");
  599. }
  600. return null;
  601. }
  602. private void changeRegistration(int castleId, int objId, boolean delete)
  603. {
  604. final String query = delete ? DELETE : INSERT;
  605. try (Connection con = L2DatabaseFactory.getInstance().getConnection();
  606. PreparedStatement statement = con.prepareStatement(query))
  607. {
  608. statement.setInt(1, castleId);
  609. statement.setInt(2, objId);
  610. statement.execute();
  611. }
  612. catch (Exception e)
  613. {
  614. _log.log(Level.WARNING, "Exception: Territory War registration: " + e.getMessage(), e);
  615. }
  616. }
  617. private void updateTerritoryData(Territory ter)
  618. {
  619. try (Connection con = L2DatabaseFactory.getInstance().getConnection())
  620. {
  621. PreparedStatement statement = con.prepareStatement("UPDATE territories SET ownedWardIds=? WHERE territoryId=?");
  622. StringBuilder wardList = new StringBuilder();
  623. for (int i : ter.getOwnedWardIds())
  624. wardList.append(i + ";");
  625. statement.setString(1, wardList.toString());
  626. statement.setInt(2, ter.getTerritoryId());
  627. statement.execute();
  628. statement.close();
  629. }
  630. catch (Exception e)
  631. {
  632. _log.log(Level.WARNING, "Exception: Territory Data update: " + e.getMessage(), e);
  633. }
  634. }
  635. private final void load()
  636. {
  637. L2Properties territoryWarSettings = new L2Properties();
  638. try (InputStream is = new FileInputStream(new File(Config.TW_CONFIGURATION_FILE)))
  639. {
  640. territoryWarSettings.load(is);
  641. }
  642. catch (IOException e)
  643. {
  644. _log.log(Level.WARNING, "Error while loading Territory War Manager settings!", e);
  645. }
  646. // Siege setting
  647. DEFENDERMAXCLANS = Integer.decode(territoryWarSettings.getProperty("DefenderMaxClans", "500"));
  648. DEFENDERMAXPLAYERS = Integer.decode(territoryWarSettings.getProperty("DefenderMaxPlayers", "500"));
  649. CLANMINLEVEL = Integer.decode(territoryWarSettings.getProperty("ClanMinLevel", "0"));
  650. PLAYERMINLEVEL = Integer.decode(territoryWarSettings.getProperty("PlayerMinLevel", "40"));
  651. WARLENGTH = Long.decode(territoryWarSettings.getProperty("WarLength", "120")) * 60000;
  652. PLAYER_WITH_WARD_CAN_BE_KILLED_IN_PEACEZONE = Boolean.parseBoolean(territoryWarSettings.getProperty("PlayerWithWardCanBeKilledInPeaceZone", "False"));
  653. SPAWN_WARDS_WHEN_TW_IS_NOT_IN_PROGRESS = Boolean.parseBoolean(territoryWarSettings.getProperty("SpawnWardsWhenTWIsNotInProgress", "False"));
  654. RETURN_WARDS_WHEN_TW_STARTS = Boolean.parseBoolean(territoryWarSettings.getProperty("ReturnWardsWhenTWStarts", "False"));
  655. MINTWBADGEFORNOBLESS = Integer.decode(territoryWarSettings.getProperty("MinTerritoryBadgeForNobless", "100"));
  656. MINTWBADGEFORSTRIDERS = Integer.decode(territoryWarSettings.getProperty("MinTerritoryBadgeForStriders", "50"));
  657. MINTWBADGEFORBIGSTRIDER = Integer.decode(territoryWarSettings.getProperty("MinTerritoryBadgeForBigStrider", "80"));
  658. try (Connection con = L2DatabaseFactory.getInstance().getConnection())
  659. {
  660. PreparedStatement statement = con.prepareStatement("SELECT * FROM territory_spawnlist");
  661. ResultSet rs = statement.executeQuery();
  662. while (rs.next())
  663. {
  664. int castleId = rs.getInt("castleId");
  665. int npcId = rs.getInt("npcId");
  666. Location loc = new Location(rs.getInt("x"),rs.getInt("y"),rs.getInt("z"),rs.getInt("heading"));
  667. int spawnType = rs.getInt("spawnType");
  668. if (!_territoryList.containsKey(castleId))
  669. _territoryList.put(castleId, new Territory(castleId));
  670. switch(spawnType)
  671. {
  672. case 0: // town npcs
  673. case 1: // fortress npcs
  674. case 2: // castle npcs
  675. _territoryList.get(castleId).getSpawnList().add(new TerritoryNPCSpawn(castleId, loc, npcId, spawnType, null));
  676. break;
  677. case 3: // ward spawns
  678. _territoryList.get(castleId).addWardSpawnPlace(loc);
  679. break;
  680. default:
  681. _log.warning("Territory War Manager: Unknown npc type for " + rs.getInt("id"));
  682. }
  683. }
  684. rs.close();
  685. statement.close();
  686. }
  687. catch (Exception e)
  688. {
  689. _log.log(Level.WARNING, "Territory War Manager: SpawnList error: " + e.getMessage(), e);
  690. }
  691. try (Connection con = L2DatabaseFactory.getInstance().getConnection())
  692. {
  693. PreparedStatement statement = con.prepareStatement("SELECT * FROM territories");
  694. ResultSet rs = statement.executeQuery();
  695. while (rs.next())
  696. {
  697. int castleId = rs.getInt("castleId");
  698. int fortId = rs.getInt("fortId");
  699. String ownedWardIds = rs.getString("OwnedWardIds");
  700. Territory t = _territoryList.get(castleId);
  701. if (t != null)
  702. {
  703. t._fortId = fortId;
  704. if (CastleManager.getInstance().getCastleById(castleId).getOwnerId() > 0)
  705. {
  706. t.setOwnerClan(ClanTable.getInstance().getClan(CastleManager.getInstance().getCastleById(castleId).getOwnerId()));
  707. t.changeNPCsSpawn(0, true);
  708. }
  709. if (!ownedWardIds.isEmpty())
  710. {
  711. for(String wardId:ownedWardIds.split(";"))
  712. if (Integer.parseInt(wardId) > 0)
  713. addTerritoryWard(Integer.parseInt(wardId), castleId, 0, false);
  714. }
  715. }
  716. }
  717. rs.close();
  718. statement.close();
  719. }
  720. catch (Exception e)
  721. {
  722. _log.log(Level.WARNING, "Territory War Manager: territory list error(): " + e.getMessage(), e);
  723. }
  724. try (Connection con = L2DatabaseFactory.getInstance().getConnection())
  725. {
  726. PreparedStatement statement = con.prepareStatement("SELECT * FROM territory_registrations");
  727. ResultSet rs = statement.executeQuery();
  728. while (rs.next())
  729. {
  730. int castleId = rs.getInt("castleId");
  731. int registeredId = rs.getInt("registeredId");
  732. if (ClanTable.getInstance().getClan(registeredId) != null)
  733. {
  734. if (_registeredClans.get(castleId) == null)
  735. _registeredClans.put(castleId, new FastList<L2Clan>());
  736. _registeredClans.get(castleId).add(ClanTable.getInstance().getClan(registeredId));
  737. }
  738. else
  739. {
  740. if (_registeredMercenaries.get(castleId) == null)
  741. _registeredMercenaries.put(castleId, new FastList<Integer>());
  742. _registeredMercenaries.get(castleId).add(registeredId);
  743. }
  744. }
  745. rs.close();
  746. statement.close();
  747. }
  748. catch (Exception e)
  749. {
  750. _log.log(Level.WARNING, "Territory War Manager: registration list error: " + e.getMessage(), e);
  751. }
  752. }
  753. protected void startTerritoryWar()
  754. {
  755. if (_territoryList == null)
  756. {
  757. _log.warning("TerritoryWarManager: TerritoryList is NULL!");
  758. return;
  759. }
  760. FastList<Territory> activeTerritoryList = new FastList<>();
  761. for(Territory t : _territoryList.values())
  762. {
  763. Castle castle = CastleManager.getInstance().getCastleById(t.getCastleId());
  764. if (castle != null)
  765. {
  766. if (castle.getOwnerId() > 0)
  767. activeTerritoryList.add(t);
  768. }
  769. else
  770. _log.warning("TerritoryWarManager: Castle missing! CastleId: " + t.getCastleId());
  771. }
  772. if (activeTerritoryList.size() < 2)
  773. return;
  774. _isTWInProgress = true;
  775. if (!updatePlayerTWStateFlags(false))
  776. return;
  777. // teleportPlayer(Siege.TeleportWhoType.Attacker, MapRegionTable.TeleportWhereType.Town); // Teleport to the closest town
  778. for(Territory t : activeTerritoryList)
  779. {
  780. Castle castle = CastleManager.getInstance().getCastleById(t.getCastleId());
  781. Fort fort = FortManager.getInstance().getFortById(t.getFortId());
  782. // spawnControlTower(t.getCastleId()); // Spawn control tower
  783. if (castle != null)
  784. {
  785. t.changeNPCsSpawn(2, true);
  786. castle.spawnDoor(); // Spawn door
  787. castle.getZone().setSiegeInstance(this);
  788. castle.getZone().setIsActive(true);
  789. castle.getZone().updateZoneStatusForCharactersInside();
  790. }
  791. else
  792. _log.warning("TerritoryWarManager: Castle missing! CastleId: " + t.getCastleId());
  793. if (fort != null)
  794. {
  795. t.changeNPCsSpawn(1, true);
  796. fort.resetDoors(); // Spawn door
  797. fort.getZone().setSiegeInstance(this);
  798. fort.getZone().setIsActive(true);
  799. fort.getZone().updateZoneStatusForCharactersInside();
  800. }
  801. else
  802. _log.warning("TerritoryWarManager: Fort missing! FortId: " + t.getFortId());
  803. for(TerritoryNPCSpawn ward : t.getOwnedWard())
  804. if (ward.getNpc() != null && t.getOwnerClan() != null)
  805. {
  806. if (!ward.getNpc().isVisible())
  807. ward.setNPC(ward.getNpc().getSpawn().doSpawn());
  808. _territoryWards.add(new TerritoryWard(ward.getNpcId(), ward.getLocation().getX(), ward.getLocation().getY(), ward.getLocation().getZ(), 0, ward.getNpcId() + 13479, t.getCastleId(), ward.getNpc()));
  809. }
  810. t.getQuestDone()[0] = 0; // killed npc
  811. t.getQuestDone()[1] = 0; // captured wards
  812. }
  813. _participantPoints.clear();
  814. if (RETURN_WARDS_WHEN_TW_STARTS)
  815. for(TerritoryWard ward : _territoryWards)
  816. if (ward.getOwnerCastleId() != ward.getTerritoryId() - 80)
  817. {
  818. ward.unSpawnMe();
  819. ward.setNpc(addTerritoryWard(ward.getTerritoryId(), ward.getTerritoryId() - 80, ward.getOwnerCastleId(), false));
  820. ward.setOwnerCastleId(ward.getTerritoryId() - 80);
  821. }
  822. SystemMessage sm = SystemMessage.getSystemMessage(SystemMessageId.TERRITORY_WAR_HAS_BEGUN);
  823. Announcements.getInstance().announceToAll(sm);
  824. }
  825. protected void endTerritoryWar()
  826. {
  827. _isTWInProgress = false;
  828. if (_territoryList == null)
  829. {
  830. _log.warning("TerritoryWarManager: TerritoryList is NULL!");
  831. return;
  832. }
  833. FastList<Territory> activeTerritoryList = new FastList<>();
  834. for(Territory t : _territoryList.values())
  835. {
  836. Castle castle = CastleManager.getInstance().getCastleById(t.getCastleId());
  837. if (castle != null)
  838. {
  839. if (castle.getOwnerId() > 0)
  840. activeTerritoryList.add(t);
  841. }
  842. else
  843. _log.warning("TerritoryWarManager: Castle missing! CastleId: " + t.getCastleId());
  844. }
  845. if (activeTerritoryList.size() < 2)
  846. return;
  847. if (!updatePlayerTWStateFlags(true))
  848. return;
  849. if (_territoryWards != null)
  850. {
  851. for(TerritoryWard twWard : _territoryWards)
  852. twWard.unSpawnMe();
  853. _territoryWards.clear();
  854. }
  855. // teleportPlayer(Siege.TeleportWhoType.Attacker, MapRegionTable.TeleportWhereType.Town); // Teleport to the closest town
  856. for(Territory t : activeTerritoryList)
  857. {
  858. Castle castle = CastleManager.getInstance().getCastleById(t.getCastleId());
  859. Fort fort = FortManager.getInstance().getFortById(t.getFortId());
  860. if (castle != null)
  861. {
  862. castle.spawnDoor();
  863. t.changeNPCsSpawn(2, false);
  864. castle.getZone().setIsActive(false);
  865. castle.getZone().updateZoneStatusForCharactersInside();
  866. castle.getZone().setSiegeInstance(null);
  867. }
  868. else
  869. _log.warning("TerritoryWarManager: Castle missing! CastleId: " + t.getCastleId());
  870. if (fort != null)
  871. {
  872. t.changeNPCsSpawn(1, false);
  873. fort.getZone().setIsActive(false);
  874. fort.getZone().updateZoneStatusForCharactersInside();
  875. fort.getZone().setSiegeInstance(null);
  876. }
  877. else
  878. _log.warning("TerritoryWarManager: Fort missing! FortId: " + t.getFortId());
  879. if (t.getHQ() != null)
  880. t.getHQ().deleteMe();
  881. for(TerritoryNPCSpawn ward : t.getOwnedWard())
  882. if (ward.getNpc() != null)
  883. {
  884. if (!ward.getNpc().isVisible() && SPAWN_WARDS_WHEN_TW_IS_NOT_IN_PROGRESS)
  885. ward.setNPC(ward.getNpc().getSpawn().doSpawn());
  886. else if (ward.getNpc().isVisible() && !SPAWN_WARDS_WHEN_TW_IS_NOT_IN_PROGRESS)
  887. ward.getNpc().decayMe();
  888. }
  889. }
  890. for(L2SiegeFlagInstance flag : _clanFlags.values())
  891. flag.deleteMe();
  892. _clanFlags.clear();
  893. for(Integer castleId:_registeredClans.keySet())
  894. for(L2Clan clan:_registeredClans.get(castleId))
  895. changeRegistration(castleId, clan.getClanId(), true);
  896. for(Integer castleId:_registeredMercenaries.keySet())
  897. for(Integer pl_objId:_registeredMercenaries.get(castleId))
  898. changeRegistration(castleId, pl_objId, true);
  899. // change next TW date
  900. SystemMessage sm = SystemMessage.getSystemMessage(SystemMessageId.TERRITORY_WAR_HAS_ENDED);
  901. Announcements.getInstance().announceToAll(sm);
  902. }
  903. protected boolean updatePlayerTWStateFlags(boolean clear)
  904. {
  905. Quest twQuest = QuestManager.getInstance().getQuest(qn);
  906. if (twQuest == null)
  907. {
  908. _log.warning("TerritoryWarManager: missing main Quest!");
  909. return false;
  910. }
  911. for(int castleId : _registeredClans.keySet())
  912. for(L2Clan clan : _registeredClans.get(castleId))
  913. for(L2PcInstance player : clan.getOnlineMembers(0))
  914. {
  915. if (player == null)
  916. continue;
  917. if (clear)
  918. {
  919. player.setSiegeState((byte) 0);
  920. if (!_isTWChannelOpen)
  921. player.setSiegeSide(0);
  922. }
  923. else
  924. {
  925. if (player.getLevel() < PLAYERMINLEVEL || player.getClassId().level() < 2)
  926. continue;
  927. if (_isTWInProgress)
  928. {
  929. player.setSiegeState((byte) 1);
  930. }
  931. player.setSiegeSide(80 + castleId);
  932. }
  933. player.broadcastUserInfo();
  934. }
  935. for(int castleId : _registeredMercenaries.keySet())
  936. for(int objId : _registeredMercenaries.get(castleId))
  937. {
  938. L2PcInstance player = L2World.getInstance().getPlayer(objId);
  939. if (player == null)
  940. continue;
  941. if (clear)
  942. {
  943. player.setSiegeState((byte) 0);
  944. if (!_isTWChannelOpen)
  945. player.setSiegeSide(0);
  946. }
  947. else
  948. {
  949. if (_isTWInProgress)
  950. {
  951. player.setSiegeState((byte) 1);
  952. }
  953. player.setSiegeSide(80 + castleId);
  954. }
  955. player.broadcastUserInfo();
  956. }
  957. for(Territory terr : _territoryList.values())
  958. if (terr.getOwnerClan() != null)
  959. for(L2PcInstance player : terr.getOwnerClan().getOnlineMembers(0))
  960. {
  961. if (player == null)
  962. continue;
  963. if (clear)
  964. {
  965. player.setSiegeState((byte) 0);
  966. if (!_isTWChannelOpen)
  967. player.setSiegeSide(0);
  968. }
  969. else
  970. {
  971. if (player.getLevel() < PLAYERMINLEVEL || player.getClassId().level() < 2)
  972. continue;
  973. if (_isTWInProgress)
  974. {
  975. player.setSiegeState((byte) 1);
  976. }
  977. player.setSiegeSide(80 + terr.getCastleId());
  978. }
  979. player.broadcastUserInfo();
  980. }
  981. twQuest.setOnEnterWorld(_isTWInProgress);
  982. return true;
  983. }
  984. protected class RewardOnlineParticipants implements Runnable
  985. {
  986. @Override
  987. public void run()
  988. {
  989. if (isTWInProgress())
  990. {
  991. for(L2PcInstance player : L2World.getInstance().getAllPlayersArray())
  992. if (player != null && player.getSiegeSide() > 0)
  993. giveTWPoint(player, 1000, 6);
  994. }
  995. else
  996. _scheduledRewardOnlineTask.cancel(false);
  997. }
  998. }
  999. protected class ScheduleStartTWTask implements Runnable
  1000. {
  1001. private final Logger _log = Logger.getLogger(ScheduleStartTWTask.class.getName());
  1002. @Override
  1003. public void run()
  1004. {
  1005. _scheduledStartTWTask.cancel(false);
  1006. try
  1007. {
  1008. long timeRemaining = _startTWDate.getTimeInMillis() - Calendar.getInstance().getTimeInMillis();
  1009. if (timeRemaining > 7200000)
  1010. {
  1011. _isRegistrationOver = false;
  1012. _scheduledStartTWTask = ThreadPoolManager.getInstance().scheduleGeneral(new ScheduleStartTWTask(), timeRemaining - 7200000); // Prepare task for 2h before TW start to end registration
  1013. }
  1014. else if ((timeRemaining <= 7200000) && (timeRemaining > 1200000))
  1015. {
  1016. SystemMessage sm = SystemMessage.getSystemMessage(SystemMessageId.THE_TERRITORY_WAR_REGISTERING_PERIOD_ENDED);
  1017. Announcements.getInstance().announceToAll(sm);
  1018. _isRegistrationOver = true;
  1019. _scheduledStartTWTask = ThreadPoolManager.getInstance().scheduleGeneral(new ScheduleStartTWTask(), timeRemaining - 1200000); // Prepare task for 20 mins left before TW start.
  1020. }
  1021. else if ((timeRemaining <= 1200000) && (timeRemaining > 600000))
  1022. {
  1023. SystemMessage sm = SystemMessage.getSystemMessage(SystemMessageId.TERRITORY_WAR_BEGINS_IN_20_MINUTES);
  1024. Announcements.getInstance().announceToAll(sm);
  1025. _isTWChannelOpen = true;
  1026. _isRegistrationOver = true;
  1027. updatePlayerTWStateFlags(false);
  1028. _scheduledStartTWTask = ThreadPoolManager.getInstance().scheduleGeneral(new ScheduleStartTWTask(), timeRemaining - 600000); // Prepare task for 10 mins left before TW start.
  1029. }
  1030. else if ((timeRemaining <= 600000) && (timeRemaining > 300000))
  1031. {
  1032. SystemMessage sm = SystemMessage.getSystemMessage(SystemMessageId.TERRITORY_WAR_BEGINS_IN_10_MINUTES);
  1033. Announcements.getInstance().announceToAll(sm);
  1034. _isTWChannelOpen = true;
  1035. _isRegistrationOver = true;
  1036. updatePlayerTWStateFlags(false);
  1037. _scheduledStartTWTask = ThreadPoolManager.getInstance().scheduleGeneral(new ScheduleStartTWTask(), timeRemaining - 300000); // Prepare task for 5 mins left before TW start.
  1038. }
  1039. else if ((timeRemaining <= 300000) && (timeRemaining > 60000))
  1040. {
  1041. SystemMessage sm = SystemMessage.getSystemMessage(SystemMessageId.TERRITORY_WAR_BEGINS_IN_5_MINUTES);
  1042. Announcements.getInstance().announceToAll(sm);
  1043. _isTWChannelOpen = true;
  1044. _isRegistrationOver = true;
  1045. updatePlayerTWStateFlags(false);
  1046. _scheduledStartTWTask = ThreadPoolManager.getInstance().scheduleGeneral(new ScheduleStartTWTask(), timeRemaining - 60000); // Prepare task for 1 min left before TW start.
  1047. }
  1048. else if ((timeRemaining <= 60000) && (timeRemaining > 0))
  1049. {
  1050. SystemMessage sm = SystemMessage.getSystemMessage(SystemMessageId.TERRITORY_WAR_BEGINS_IN_1_MINUTE);
  1051. Announcements.getInstance().announceToAll(sm);
  1052. _isTWChannelOpen = true;
  1053. _isRegistrationOver = true;
  1054. updatePlayerTWStateFlags(false);
  1055. _scheduledStartTWTask = ThreadPoolManager.getInstance().scheduleGeneral(new ScheduleStartTWTask(), timeRemaining); // Prepare task for TW start.
  1056. }
  1057. else if ((timeRemaining + WARLENGTH) > 0)
  1058. {
  1059. _isTWChannelOpen = true;
  1060. _isRegistrationOver = true;
  1061. startTerritoryWar();
  1062. _scheduledEndTWTask = ThreadPoolManager.getInstance().scheduleGeneral(new ScheduleEndTWTask(), 1000); // Prepare task for TW end.
  1063. _scheduledRewardOnlineTask = ThreadPoolManager.getInstance().scheduleGeneralAtFixedRate(new RewardOnlineParticipants(), 60000, 60000);
  1064. }
  1065. }
  1066. catch (Exception e)
  1067. {
  1068. _log.log(Level.SEVERE, "", e);
  1069. }
  1070. }
  1071. }
  1072. private class ScheduleEndTWTask implements Runnable
  1073. {
  1074. private final Logger _log = Logger.getLogger(ScheduleEndTWTask.class.getName());
  1075. protected ScheduleEndTWTask()
  1076. {
  1077. }
  1078. @Override
  1079. public void run()
  1080. {
  1081. try
  1082. {
  1083. _scheduledEndTWTask.cancel(false);
  1084. long timeRemaining = _startTWDate.getTimeInMillis() + WARLENGTH - Calendar.getInstance().getTimeInMillis();
  1085. if (timeRemaining > 3600000)
  1086. {
  1087. SystemMessage sm = SystemMessage.getSystemMessage(SystemMessageId.THE_TERRITORY_WAR_WILL_END_IN_S1_HOURS);
  1088. sm.addNumber(2);
  1089. announceToParticipants(sm, 0, 0);
  1090. _scheduledEndTWTask = ThreadPoolManager.getInstance().scheduleGeneral(new ScheduleEndTWTask(), timeRemaining - 3600000); // Prepare task for 1 hr left.
  1091. }
  1092. else if ((timeRemaining <= 3600000) && (timeRemaining > 600000))
  1093. {
  1094. SystemMessage sm = SystemMessage.getSystemMessage(SystemMessageId.THE_TERRITORY_WAR_WILL_END_IN_S1_MINUTES);
  1095. sm.addNumber((int) (timeRemaining / 60000));
  1096. announceToParticipants(sm, 0, 0);
  1097. _scheduledEndTWTask = ThreadPoolManager.getInstance().scheduleGeneral(new ScheduleEndTWTask(), timeRemaining - 600000); // Prepare task for 10 minute left.
  1098. }
  1099. else if ((timeRemaining <= 600000) && (timeRemaining > 300000))
  1100. {
  1101. SystemMessage sm = SystemMessage.getSystemMessage(SystemMessageId.THE_TERRITORY_WAR_WILL_END_IN_S1_MINUTES);
  1102. sm.addNumber((int) (timeRemaining / 60000));
  1103. announceToParticipants(sm, 0, 0);
  1104. _scheduledEndTWTask = ThreadPoolManager.getInstance().scheduleGeneral(new ScheduleEndTWTask(), timeRemaining - 300000); // Prepare task for 5 minute left.
  1105. }
  1106. else if ((timeRemaining <= 300000) && (timeRemaining > 10000))
  1107. {
  1108. SystemMessage sm = SystemMessage.getSystemMessage(SystemMessageId.THE_TERRITORY_WAR_WILL_END_IN_S1_MINUTES);
  1109. sm.addNumber((int) (timeRemaining / 60000));
  1110. announceToParticipants(sm, 0, 0);
  1111. _scheduledEndTWTask = ThreadPoolManager.getInstance().scheduleGeneral(new ScheduleEndTWTask(), timeRemaining - 10000); // Prepare task for 10 seconds count down
  1112. }
  1113. else if ((timeRemaining <= 10000) && (timeRemaining > 0))
  1114. {
  1115. SystemMessage sm = SystemMessage.getSystemMessage(SystemMessageId.S1_SECONDS_TO_THE_END_OF_TERRITORY_WAR);
  1116. sm.addNumber((int) (timeRemaining / 1000));
  1117. announceToParticipants(sm, 0, 0);
  1118. _scheduledEndTWTask = ThreadPoolManager.getInstance().scheduleGeneral(new ScheduleEndTWTask(), timeRemaining); // Prepare task for second count down
  1119. }
  1120. else
  1121. {
  1122. endTerritoryWar();
  1123. // _scheduledStartTWTask = ThreadPoolManager.getInstance().scheduleGeneral(new ScheduleStartTWTask(), 1000);
  1124. ThreadPoolManager.getInstance().scheduleGeneral(new closeTerritoryChannelTask(), 600000);
  1125. }
  1126. }
  1127. catch (Exception e)
  1128. {
  1129. _log.log(Level.SEVERE, "", e);
  1130. }
  1131. }
  1132. }
  1133. private class closeTerritoryChannelTask implements Runnable
  1134. {
  1135. public closeTerritoryChannelTask()
  1136. {
  1137. }
  1138. @Override
  1139. public void run()
  1140. {
  1141. _isTWChannelOpen = false;
  1142. _disguisedPlayers.clear();
  1143. updatePlayerTWStateFlags(true);
  1144. }
  1145. }
  1146. public void announceToParticipants(L2GameServerPacket sm, int exp, int sp)
  1147. {
  1148. // broadcast to clan members
  1149. for(Territory ter : _territoryList.values())
  1150. if (ter.getOwnerClan() != null)
  1151. for (L2PcInstance member : ter.getOwnerClan().getOnlineMembers(0))
  1152. {
  1153. member.sendPacket(sm);
  1154. if (exp > 0 || sp > 0)
  1155. member.addExpAndSp(exp, sp);
  1156. }
  1157. for(FastList<L2Clan> list:_registeredClans.values())
  1158. for(L2Clan c:list)
  1159. for (L2PcInstance member : c.getOnlineMembers(0))
  1160. {
  1161. member.sendPacket(sm);
  1162. if (exp > 0 || sp > 0)
  1163. member.addExpAndSp(exp, sp);
  1164. }
  1165. // broadcast to mercenaries
  1166. for(FastList<Integer> list:_registeredMercenaries.values())
  1167. for(int objId:list)
  1168. {
  1169. L2PcInstance player = L2World.getInstance().getPlayer(objId);
  1170. if (player != null && (player.getClan() == null || !checkIsRegistered(-1, player.getClan())))
  1171. {
  1172. player.sendPacket(sm);
  1173. if (exp > 0 || sp > 0)
  1174. player.addExpAndSp(exp, sp);
  1175. }
  1176. }
  1177. }
  1178. public static class TerritoryNPCSpawn
  1179. {
  1180. private Location _location;
  1181. protected int _npcId;
  1182. private int _castleId;
  1183. private int _type;
  1184. private L2Npc _npc;
  1185. public TerritoryNPCSpawn(int castle_id, Location loc, int npc_id, int type, L2Npc npc)
  1186. {
  1187. _castleId = castle_id;
  1188. _location = loc;
  1189. _npcId = npc_id;
  1190. _type = type;
  1191. _npc = npc;
  1192. }
  1193. public int getCastleId()
  1194. {
  1195. return _castleId;
  1196. }
  1197. public int getNpcId()
  1198. {
  1199. return _npcId;
  1200. }
  1201. public int getType()
  1202. {
  1203. return _type;
  1204. }
  1205. public void setNPC(L2Npc npc)
  1206. {
  1207. if (_npc != null)
  1208. _npc.deleteMe();
  1209. _npc = npc;
  1210. }
  1211. public L2Npc getNpc()
  1212. {
  1213. return _npc;
  1214. }
  1215. public Location getLocation()
  1216. {
  1217. return _location;
  1218. }
  1219. }
  1220. public class Territory
  1221. {
  1222. private final Logger _log = Logger.getLogger(Territory.class.getName());
  1223. private final int _territoryId;
  1224. private final int _castleId; // territory Castle
  1225. protected int _fortId; // territory Fortress
  1226. private L2Clan _ownerClan;
  1227. private FastList<TerritoryNPCSpawn> _spawnList;
  1228. private TerritoryNPCSpawn[] _territoryWardSpawnPlaces;
  1229. private boolean _isInProgress = false;
  1230. private L2SiegeFlagInstance _territoryHQ = null;
  1231. private int[] _questDone;
  1232. public Territory(int castleId)
  1233. {
  1234. _castleId = castleId;
  1235. _territoryId = castleId + 80;
  1236. _spawnList = new FastList<>();
  1237. _territoryWardSpawnPlaces = new TerritoryNPCSpawn[9];
  1238. _questDone = new int[2];
  1239. }
  1240. protected void addWardSpawnPlace(Location loc)
  1241. {
  1242. for(int i = 0; i < _territoryWardSpawnPlaces.length; i++)
  1243. if (_territoryWardSpawnPlaces[i] == null)
  1244. {
  1245. _territoryWardSpawnPlaces[i] = new TerritoryNPCSpawn(_castleId, loc, 0, 4, null);
  1246. return;
  1247. }
  1248. }
  1249. protected TerritoryNPCSpawn getFreeWardSpawnPlace()
  1250. {
  1251. for(int i = 0; i < _territoryWardSpawnPlaces.length; i++)
  1252. if (_territoryWardSpawnPlaces[i] != null && _territoryWardSpawnPlaces[i].getNpc() == null)
  1253. return _territoryWardSpawnPlaces[i];
  1254. _log.log(Level.WARNING, "TerritoryWarManager: no free Ward spawn found for territory: " + _territoryId);
  1255. for(int i = 0; i < _territoryWardSpawnPlaces.length; i++)
  1256. if (_territoryWardSpawnPlaces[i] == null)
  1257. _log.log(Level.WARNING, "TerritoryWarManager: territory ward spawn place " + i + " is null!");
  1258. else if (_territoryWardSpawnPlaces[i].getNpc() != null)
  1259. _log.log(Level.WARNING, "TerritoryWarManager: territory ward spawn place " + i + " has npc name: " + _territoryWardSpawnPlaces[i].getNpc().getName());
  1260. else
  1261. _log.log(Level.WARNING, "TerritoryWarManager: territory ward spawn place " + i + " is empty!");
  1262. return null;
  1263. }
  1264. public FastList<TerritoryNPCSpawn> getSpawnList()
  1265. {
  1266. return _spawnList;
  1267. }
  1268. protected void changeNPCsSpawn(int type, boolean isSpawn)
  1269. {
  1270. if (type < 0 || type > 3)
  1271. {
  1272. _log.log(Level.WARNING, "TerritoryWarManager: wrong type(" + type + ") for NPCs spawn change!");
  1273. return;
  1274. }
  1275. for(TerritoryNPCSpawn twSpawn : _spawnList)
  1276. {
  1277. if (twSpawn.getType() != type)
  1278. continue;
  1279. if (isSpawn)
  1280. twSpawn.setNPC(spawnNPC(twSpawn.getNpcId(), twSpawn.getLocation()));
  1281. else
  1282. {
  1283. L2Npc npc = twSpawn.getNpc();
  1284. if (npc != null && !npc.isDead())
  1285. npc.deleteMe();
  1286. twSpawn.setNPC(null);
  1287. }
  1288. }
  1289. }
  1290. protected void removeWard(int wardId)
  1291. {
  1292. for(TerritoryNPCSpawn wardSpawn : _territoryWardSpawnPlaces)
  1293. if (wardSpawn.getNpcId() == wardId)
  1294. {
  1295. wardSpawn.getNpc().deleteMe();
  1296. wardSpawn.setNPC(null);
  1297. wardSpawn._npcId = 0;
  1298. return;
  1299. }
  1300. _log.log(Level.WARNING, "TerritoryWarManager: cant delete wardId: " + wardId + " for territory: " + _territoryId);
  1301. }
  1302. public int getTerritoryId()
  1303. {
  1304. return _territoryId;
  1305. }
  1306. public int getCastleId()
  1307. {
  1308. return _castleId;
  1309. }
  1310. public int getFortId()
  1311. {
  1312. return _fortId;
  1313. }
  1314. public L2Clan getOwnerClan()
  1315. {
  1316. return _ownerClan;
  1317. }
  1318. public void setOwnerClan(L2Clan newOwner)
  1319. {
  1320. _ownerClan = newOwner;
  1321. }
  1322. public void setHQ(L2SiegeFlagInstance hq)
  1323. {
  1324. _territoryHQ = hq;
  1325. }
  1326. public L2SiegeFlagInstance getHQ()
  1327. {
  1328. return _territoryHQ;
  1329. }
  1330. public TerritoryNPCSpawn[] getOwnedWard()
  1331. {
  1332. return _territoryWardSpawnPlaces;
  1333. }
  1334. public int[] getQuestDone()
  1335. {
  1336. return _questDone;
  1337. }
  1338. public FastList<Integer> getOwnedWardIds()
  1339. {
  1340. FastList<Integer> ret = new FastList<>();
  1341. for(TerritoryNPCSpawn wardSpawn : _territoryWardSpawnPlaces)
  1342. if (wardSpawn.getNpcId() > 0)
  1343. ret.add(wardSpawn.getNpcId());
  1344. return ret;
  1345. }
  1346. public boolean getIsInProgress()
  1347. {
  1348. return _isInProgress;
  1349. }
  1350. public void setIsInProgress(boolean val)
  1351. {
  1352. _isInProgress = val;
  1353. }
  1354. }
  1355. private static class SingletonHolder
  1356. {
  1357. protected static final TerritoryWarManager _instance = new TerritoryWarManager();
  1358. }
  1359. @Override
  1360. public void startSiege()
  1361. {
  1362. throw new UnsupportedOperationException();
  1363. }
  1364. @Override
  1365. public void endSiege()
  1366. {
  1367. throw new UnsupportedOperationException();
  1368. }
  1369. @Override
  1370. public L2SiegeClan getAttackerClan(int clanId)
  1371. {
  1372. throw new UnsupportedOperationException();
  1373. }
  1374. @Override
  1375. public L2SiegeClan getAttackerClan(L2Clan clan)
  1376. {
  1377. throw new UnsupportedOperationException();
  1378. }
  1379. @Override
  1380. public List<L2SiegeClan> getAttackerClans()
  1381. {
  1382. throw new UnsupportedOperationException();
  1383. }
  1384. @Override
  1385. public List<L2PcInstance> getAttackersInZone()
  1386. {
  1387. throw new UnsupportedOperationException();
  1388. }
  1389. @Override
  1390. public boolean checkIsAttacker(L2Clan clan)
  1391. {
  1392. throw new UnsupportedOperationException();
  1393. }
  1394. @Override
  1395. public L2SiegeClan getDefenderClan(int clanId)
  1396. {
  1397. throw new UnsupportedOperationException();
  1398. }
  1399. @Override
  1400. public L2SiegeClan getDefenderClan(L2Clan clan)
  1401. {
  1402. throw new UnsupportedOperationException();
  1403. }
  1404. @Override
  1405. public List<L2SiegeClan> getDefenderClans()
  1406. {
  1407. throw new UnsupportedOperationException();
  1408. }
  1409. @Override
  1410. public boolean checkIsDefender(L2Clan clan)
  1411. {
  1412. throw new UnsupportedOperationException();
  1413. }
  1414. @Override
  1415. public List<L2Npc> getFlag(L2Clan clan)
  1416. {
  1417. throw new UnsupportedOperationException();
  1418. }
  1419. @Override
  1420. public Calendar getSiegeDate()
  1421. {
  1422. throw new UnsupportedOperationException();
  1423. }
  1424. @Override
  1425. public boolean giveFame()
  1426. {
  1427. return true;
  1428. }
  1429. @Override
  1430. public int getFameFrequency()
  1431. {
  1432. return Config.CASTLE_ZONE_FAME_TASK_FREQUENCY;
  1433. }
  1434. @Override
  1435. public int getFameAmount()
  1436. {
  1437. return Config.CASTLE_ZONE_FAME_AQUIRE_POINTS;
  1438. }
  1439. @Override
  1440. public void updateSiege()
  1441. {
  1442. }
  1443. }