Castle.java 30 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183
  1. /*
  2. * Copyright (C) 2004-2014 L2J Server
  3. *
  4. * This file is part of L2J Server.
  5. *
  6. * L2J Server is free software: you can redistribute it and/or modify
  7. * it under the terms of the GNU General Public License as published by
  8. * the Free Software Foundation, either version 3 of the License, or
  9. * (at your option) any later version.
  10. *
  11. * L2J Server is distributed in the hope that it will be useful,
  12. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  14. * General Public License for more details.
  15. *
  16. * You should have received a copy of the GNU General Public License
  17. * along with this program. If not, see <http://www.gnu.org/licenses/>.
  18. */
  19. package com.l2jserver.gameserver.model.entity;
  20. import java.sql.Connection;
  21. import java.sql.PreparedStatement;
  22. import java.sql.ResultSet;
  23. import java.util.ArrayList;
  24. import java.util.Calendar;
  25. import java.util.List;
  26. import java.util.Map;
  27. import java.util.logging.Level;
  28. import java.util.logging.Logger;
  29. import javolution.util.FastMap;
  30. import com.l2jserver.Config;
  31. import com.l2jserver.L2DatabaseFactory;
  32. import com.l2jserver.gameserver.ThreadPoolManager;
  33. import com.l2jserver.gameserver.datatables.ClanTable;
  34. import com.l2jserver.gameserver.datatables.DoorTable;
  35. import com.l2jserver.gameserver.datatables.SkillData;
  36. import com.l2jserver.gameserver.datatables.SkillTreesData;
  37. import com.l2jserver.gameserver.enums.MountType;
  38. import com.l2jserver.gameserver.instancemanager.CastleManager;
  39. import com.l2jserver.gameserver.instancemanager.CastleManorManager;
  40. import com.l2jserver.gameserver.instancemanager.FortManager;
  41. import com.l2jserver.gameserver.instancemanager.SiegeManager;
  42. import com.l2jserver.gameserver.instancemanager.TerritoryWarManager;
  43. import com.l2jserver.gameserver.instancemanager.TerritoryWarManager.Territory;
  44. import com.l2jserver.gameserver.instancemanager.ZoneManager;
  45. import com.l2jserver.gameserver.model.L2Clan;
  46. import com.l2jserver.gameserver.model.L2Object;
  47. import com.l2jserver.gameserver.model.L2SkillLearn;
  48. import com.l2jserver.gameserver.model.TowerSpawn;
  49. import com.l2jserver.gameserver.model.actor.instance.L2ArtefactInstance;
  50. import com.l2jserver.gameserver.model.actor.instance.L2DoorInstance;
  51. import com.l2jserver.gameserver.model.actor.instance.L2PcInstance;
  52. import com.l2jserver.gameserver.model.itemcontainer.Inventory;
  53. import com.l2jserver.gameserver.model.skills.Skill;
  54. import com.l2jserver.gameserver.model.zone.type.L2CastleZone;
  55. import com.l2jserver.gameserver.model.zone.type.L2ResidenceTeleportZone;
  56. import com.l2jserver.gameserver.model.zone.type.L2SiegeZone;
  57. import com.l2jserver.gameserver.network.SystemMessageId;
  58. import com.l2jserver.gameserver.network.serverpackets.PlaySound;
  59. import com.l2jserver.gameserver.network.serverpackets.PledgeShowInfoUpdate;
  60. import com.l2jserver.gameserver.network.serverpackets.SystemMessage;
  61. public final class Castle extends AbstractResidence
  62. {
  63. protected static final Logger _log = Logger.getLogger(Castle.class.getName());
  64. private final List<L2DoorInstance> _doors = new ArrayList<>();
  65. private int _ownerId = 0;
  66. private Siege _siege = null;
  67. private Calendar _siegeDate;
  68. private boolean _isTimeRegistrationOver = true; // true if Castle Lords set the time, or 24h is elapsed after the siege
  69. private Calendar _siegeTimeRegistrationEndDate; // last siege end date + 1 day
  70. private int _taxPercent = 0;
  71. private double _taxRate = 0;
  72. private long _treasury = 0;
  73. private boolean _showNpcCrest = false;
  74. private L2SiegeZone _zone = null;
  75. private L2ResidenceTeleportZone _teleZone;
  76. private L2Clan _formerOwner = null;
  77. private final List<L2ArtefactInstance> _artefacts = new ArrayList<>(1);
  78. private final Map<Integer, CastleFunction> _function;
  79. private int _ticketBuyCount = 0;
  80. /** Castle Functions */
  81. public static final int FUNC_TELEPORT = 1;
  82. public static final int FUNC_RESTORE_HP = 2;
  83. public static final int FUNC_RESTORE_MP = 3;
  84. public static final int FUNC_RESTORE_EXP = 4;
  85. public static final int FUNC_SUPPORT = 5;
  86. public class CastleFunction
  87. {
  88. private final int _type;
  89. private int _lvl;
  90. protected int _fee;
  91. protected int _tempFee;
  92. private final long _rate;
  93. private long _endDate;
  94. protected boolean _inDebt;
  95. public boolean _cwh;
  96. public CastleFunction(int type, int lvl, int lease, int tempLease, long rate, long time, boolean cwh)
  97. {
  98. _type = type;
  99. _lvl = lvl;
  100. _fee = lease;
  101. _tempFee = tempLease;
  102. _rate = rate;
  103. _endDate = time;
  104. initializeTask(cwh);
  105. }
  106. public int getType()
  107. {
  108. return _type;
  109. }
  110. public int getLvl()
  111. {
  112. return _lvl;
  113. }
  114. public int getLease()
  115. {
  116. return _fee;
  117. }
  118. public long getRate()
  119. {
  120. return _rate;
  121. }
  122. public long getEndTime()
  123. {
  124. return _endDate;
  125. }
  126. public void setLvl(int lvl)
  127. {
  128. _lvl = lvl;
  129. }
  130. public void setLease(int lease)
  131. {
  132. _fee = lease;
  133. }
  134. public void setEndTime(long time)
  135. {
  136. _endDate = time;
  137. }
  138. private void initializeTask(boolean cwh)
  139. {
  140. if (getOwnerId() <= 0)
  141. {
  142. return;
  143. }
  144. long currentTime = System.currentTimeMillis();
  145. if (_endDate > currentTime)
  146. {
  147. ThreadPoolManager.getInstance().scheduleGeneral(new FunctionTask(cwh), _endDate - currentTime);
  148. }
  149. else
  150. {
  151. ThreadPoolManager.getInstance().scheduleGeneral(new FunctionTask(cwh), 0);
  152. }
  153. }
  154. private class FunctionTask implements Runnable
  155. {
  156. public FunctionTask(boolean cwh)
  157. {
  158. _cwh = cwh;
  159. }
  160. @Override
  161. public void run()
  162. {
  163. try
  164. {
  165. if (getOwnerId() <= 0)
  166. {
  167. return;
  168. }
  169. if ((ClanTable.getInstance().getClan(getOwnerId()).getWarehouse().getAdena() >= _fee) || !_cwh)
  170. {
  171. int fee = _fee;
  172. if (getEndTime() == -1)
  173. {
  174. fee = _tempFee;
  175. }
  176. setEndTime(System.currentTimeMillis() + getRate());
  177. dbSave();
  178. if (_cwh)
  179. {
  180. ClanTable.getInstance().getClan(getOwnerId()).getWarehouse().destroyItemByItemId("CS_function_fee", Inventory.ADENA_ID, fee, null, null);
  181. }
  182. ThreadPoolManager.getInstance().scheduleGeneral(new FunctionTask(true), getRate());
  183. }
  184. else
  185. {
  186. removeFunction(getType());
  187. }
  188. }
  189. catch (Exception e)
  190. {
  191. _log.log(Level.SEVERE, "", e);
  192. }
  193. }
  194. }
  195. public void dbSave()
  196. {
  197. try (Connection con = L2DatabaseFactory.getInstance().getConnection();
  198. PreparedStatement ps = con.prepareStatement("REPLACE INTO castle_functions (castle_id, type, lvl, lease, rate, endTime) VALUES (?,?,?,?,?,?)"))
  199. {
  200. ps.setInt(1, getResidenceId());
  201. ps.setInt(2, getType());
  202. ps.setInt(3, getLvl());
  203. ps.setInt(4, getLease());
  204. ps.setLong(5, getRate());
  205. ps.setLong(6, getEndTime());
  206. ps.execute();
  207. }
  208. catch (Exception e)
  209. {
  210. _log.log(Level.SEVERE, "Exception: Castle.updateFunctions(int type, int lvl, int lease, long rate, long time, boolean addNew): " + e.getMessage(), e);
  211. }
  212. }
  213. }
  214. public Castle(int castleId)
  215. {
  216. super(castleId);
  217. load();
  218. /*
  219. * if (getResidenceId() == 7 || castleId == 9) // Goddard and Schuttgart _nbArtifact = 2;
  220. */
  221. _function = new FastMap<>();
  222. initResidenceZone();
  223. if (getOwnerId() != 0)
  224. {
  225. loadFunctions();
  226. loadDoorUpgrade();
  227. }
  228. }
  229. /**
  230. * Return function with id
  231. * @param type
  232. * @return
  233. */
  234. public CastleFunction getFunction(int type)
  235. {
  236. if (_function.containsKey(type))
  237. {
  238. return _function.get(type);
  239. }
  240. return null;
  241. }
  242. public synchronized void engrave(L2Clan clan, L2Object target)
  243. {
  244. if (!_artefacts.contains(target))
  245. {
  246. return;
  247. }
  248. setOwner(clan);
  249. final SystemMessage msg = SystemMessage.getSystemMessage(SystemMessageId.CLAN_S1_ENGRAVED_RULER);
  250. msg.addString(clan.getName());
  251. getSiege().announceToPlayer(msg, true);
  252. }
  253. // This method add to the treasury
  254. /**
  255. * Add amount to castle instance's treasury (warehouse).
  256. * @param amount
  257. */
  258. public void addToTreasury(long amount)
  259. {
  260. // check if owned
  261. if (getOwnerId() <= 0)
  262. {
  263. return;
  264. }
  265. if (getName().equalsIgnoreCase("Schuttgart") || getName().equalsIgnoreCase("Goddard"))
  266. {
  267. Castle rune = CastleManager.getInstance().getCastle("rune");
  268. if (rune != null)
  269. {
  270. long runeTax = (long) (amount * rune.getTaxRate());
  271. if (rune.getOwnerId() > 0)
  272. {
  273. rune.addToTreasury(runeTax);
  274. }
  275. amount -= runeTax;
  276. }
  277. }
  278. if (!getName().equalsIgnoreCase("aden") && !getName().equalsIgnoreCase("Rune") && !getName().equalsIgnoreCase("Schuttgart") && !getName().equalsIgnoreCase("Goddard")) // If current castle instance is not Aden, Rune, Goddard or Schuttgart.
  279. {
  280. Castle aden = CastleManager.getInstance().getCastle("aden");
  281. if (aden != null)
  282. {
  283. long adenTax = (long) (amount * aden.getTaxRate()); // Find out what Aden gets from the current castle instance's income
  284. if (aden.getOwnerId() > 0)
  285. {
  286. aden.addToTreasury(adenTax); // Only bother to really add the tax to the treasury if not npc owned
  287. }
  288. amount -= adenTax; // Subtract Aden's income from current castle instance's income
  289. }
  290. }
  291. addToTreasuryNoTax(amount);
  292. }
  293. /**
  294. * Add amount to castle instance's treasury (warehouse), no tax paying.
  295. * @param amount
  296. * @return
  297. */
  298. public boolean addToTreasuryNoTax(long amount)
  299. {
  300. if (getOwnerId() <= 0)
  301. {
  302. return false;
  303. }
  304. if (amount < 0)
  305. {
  306. amount *= -1;
  307. if (_treasury < amount)
  308. {
  309. return false;
  310. }
  311. _treasury -= amount;
  312. }
  313. else
  314. {
  315. if ((_treasury + amount) > Inventory.MAX_ADENA)
  316. {
  317. _treasury = Inventory.MAX_ADENA;
  318. }
  319. else
  320. {
  321. _treasury += amount;
  322. }
  323. }
  324. try (Connection con = L2DatabaseFactory.getInstance().getConnection();
  325. PreparedStatement ps = con.prepareStatement("UPDATE castle SET treasury = ? WHERE id = ?"))
  326. {
  327. ps.setLong(1, getTreasury());
  328. ps.setInt(2, getResidenceId());
  329. ps.execute();
  330. }
  331. catch (Exception e)
  332. {
  333. _log.log(Level.WARNING, e.getMessage(), e);
  334. }
  335. return true;
  336. }
  337. /**
  338. * Move non clan members off castle area and to nearest town.
  339. */
  340. public void banishForeigners()
  341. {
  342. getResidenceZone().banishForeigners(getOwnerId());
  343. }
  344. /**
  345. * Return true if object is inside the zone
  346. * @param x
  347. * @param y
  348. * @param z
  349. * @return
  350. */
  351. public boolean checkIfInZone(int x, int y, int z)
  352. {
  353. return getZone().isInsideZone(x, y, z);
  354. }
  355. public L2SiegeZone getZone()
  356. {
  357. if (_zone == null)
  358. {
  359. for (L2SiegeZone zone : ZoneManager.getInstance().getAllZones(L2SiegeZone.class))
  360. {
  361. if (zone.getSiegeObjectId() == getResidenceId())
  362. {
  363. _zone = zone;
  364. break;
  365. }
  366. }
  367. }
  368. return _zone;
  369. }
  370. @Override
  371. public L2CastleZone getResidenceZone()
  372. {
  373. return (L2CastleZone) super.getResidenceZone();
  374. }
  375. public L2ResidenceTeleportZone getTeleZone()
  376. {
  377. if (_teleZone == null)
  378. {
  379. for (L2ResidenceTeleportZone zone : ZoneManager.getInstance().getAllZones(L2ResidenceTeleportZone.class))
  380. {
  381. if (zone.getResidenceId() == getResidenceId())
  382. {
  383. _teleZone = zone;
  384. break;
  385. }
  386. }
  387. }
  388. return _teleZone;
  389. }
  390. public void oustAllPlayers()
  391. {
  392. getTeleZone().oustAllPlayers();
  393. }
  394. /**
  395. * Get the objects distance to this castle
  396. * @param obj
  397. * @return
  398. */
  399. public double getDistance(L2Object obj)
  400. {
  401. return getZone().getDistanceToZone(obj);
  402. }
  403. public void closeDoor(L2PcInstance activeChar, int doorId)
  404. {
  405. openCloseDoor(activeChar, doorId, false);
  406. }
  407. public void openDoor(L2PcInstance activeChar, int doorId)
  408. {
  409. openCloseDoor(activeChar, doorId, true);
  410. }
  411. public void openCloseDoor(L2PcInstance activeChar, int doorId, boolean open)
  412. {
  413. if (activeChar.getClanId() != getOwnerId())
  414. {
  415. return;
  416. }
  417. L2DoorInstance door = getDoor(doorId);
  418. if (door != null)
  419. {
  420. if (open)
  421. {
  422. door.openMe();
  423. }
  424. else
  425. {
  426. door.closeMe();
  427. }
  428. }
  429. }
  430. // This method is used to begin removing all castle upgrades
  431. public void removeUpgrade()
  432. {
  433. removeDoorUpgrade();
  434. removeTrapUpgrade();
  435. for (Integer fc : _function.keySet())
  436. {
  437. removeFunction(fc);
  438. }
  439. _function.clear();
  440. }
  441. // This method updates the castle tax rate
  442. public void setOwner(L2Clan clan)
  443. {
  444. // Remove old owner
  445. if ((getOwnerId() > 0) && ((clan == null) || (clan.getId() != getOwnerId())))
  446. {
  447. L2Clan oldOwner = ClanTable.getInstance().getClan(getOwnerId()); // Try to find clan instance
  448. if (oldOwner != null)
  449. {
  450. if (_formerOwner == null)
  451. {
  452. _formerOwner = oldOwner;
  453. if (Config.REMOVE_CASTLE_CIRCLETS)
  454. {
  455. CastleManager.getInstance().removeCirclet(_formerOwner, getResidenceId());
  456. }
  457. }
  458. try
  459. {
  460. L2PcInstance oldleader = oldOwner.getLeader().getPlayerInstance();
  461. if (oldleader != null)
  462. {
  463. if (oldleader.getMountType() == MountType.WYVERN)
  464. {
  465. oldleader.dismount();
  466. }
  467. }
  468. }
  469. catch (Exception e)
  470. {
  471. _log.log(Level.WARNING, "Exception in setOwner: " + e.getMessage(), e);
  472. }
  473. oldOwner.setCastleId(0); // Unset has castle flag for old owner
  474. for (L2PcInstance member : oldOwner.getOnlineMembers(0))
  475. {
  476. removeResidentialSkills(member);
  477. member.sendSkillList();
  478. }
  479. }
  480. }
  481. updateOwnerInDB(clan); // Update in database
  482. setShowNpcCrest(false);
  483. // if clan have fortress, remove it
  484. if ((clan != null) && (clan.getFortId() > 0))
  485. {
  486. FortManager.getInstance().getFortByOwner(clan).removeOwner(true);
  487. }
  488. if (getSiege().isInProgress())
  489. {
  490. getSiege().midVictory(); // Mid victory phase of siege
  491. }
  492. TerritoryWarManager.getInstance().getTerritory(getResidenceId()).setOwnerClan(clan);
  493. if (clan != null)
  494. {
  495. for (L2PcInstance member : clan.getOnlineMembers(0))
  496. {
  497. giveResidentialSkills(member);
  498. member.sendSkillList();
  499. }
  500. }
  501. }
  502. public void removeOwner(L2Clan clan)
  503. {
  504. if (clan != null)
  505. {
  506. _formerOwner = clan;
  507. if (Config.REMOVE_CASTLE_CIRCLETS)
  508. {
  509. CastleManager.getInstance().removeCirclet(_formerOwner, getResidenceId());
  510. }
  511. for (L2PcInstance member : clan.getOnlineMembers(0))
  512. {
  513. removeResidentialSkills(member);
  514. member.sendSkillList();
  515. }
  516. clan.setCastleId(0);
  517. clan.broadcastToOnlineMembers(new PledgeShowInfoUpdate(clan));
  518. }
  519. updateOwnerInDB(null);
  520. if (getSiege().isInProgress())
  521. {
  522. getSiege().midVictory();
  523. }
  524. for (Integer fc : _function.keySet())
  525. {
  526. removeFunction(fc);
  527. }
  528. _function.clear();
  529. }
  530. public void setTaxPercent(int taxPercent)
  531. {
  532. _taxPercent = taxPercent;
  533. _taxRate = _taxPercent / 100.0;
  534. try (Connection con = L2DatabaseFactory.getInstance().getConnection();
  535. PreparedStatement ps = con.prepareStatement("UPDATE castle SET taxPercent = ? WHERE id = ?"))
  536. {
  537. ps.setInt(1, taxPercent);
  538. ps.setInt(2, getResidenceId());
  539. ps.execute();
  540. }
  541. catch (Exception e)
  542. {
  543. _log.log(Level.WARNING, e.getMessage(), e);
  544. }
  545. }
  546. /**
  547. * Respawn all doors on castle grounds.
  548. */
  549. public void spawnDoor()
  550. {
  551. spawnDoor(false);
  552. }
  553. /**
  554. * Respawn all doors on castle grounds<BR>
  555. * <BR>
  556. * @param isDoorWeak
  557. */
  558. public void spawnDoor(boolean isDoorWeak)
  559. {
  560. for (L2DoorInstance door : _doors)
  561. {
  562. if (door.isDead())
  563. {
  564. door.doRevive();
  565. door.setCurrentHp((isDoorWeak) ? (door.getMaxHp() / 2) : (door.getMaxHp()));
  566. }
  567. if (door.getOpen())
  568. {
  569. door.closeMe();
  570. }
  571. }
  572. }
  573. // This method loads castle
  574. @Override
  575. protected void load()
  576. {
  577. try (Connection con = L2DatabaseFactory.getInstance().getConnection();
  578. PreparedStatement ps1 = con.prepareStatement("SELECT * FROM castle WHERE id = ?");
  579. PreparedStatement ps2 = con.prepareStatement("SELECT clan_id FROM clan_data WHERE hasCastle = ?"))
  580. {
  581. ps1.setInt(1, getResidenceId());
  582. try (ResultSet rs = ps1.executeQuery())
  583. {
  584. while (rs.next())
  585. {
  586. setName(rs.getString("name"));
  587. // _OwnerId = rs.getInt("ownerId");
  588. _siegeDate = Calendar.getInstance();
  589. _siegeDate.setTimeInMillis(rs.getLong("siegeDate"));
  590. _siegeTimeRegistrationEndDate = Calendar.getInstance();
  591. _siegeTimeRegistrationEndDate.setTimeInMillis(rs.getLong("regTimeEnd"));
  592. _isTimeRegistrationOver = rs.getBoolean("regTimeOver");
  593. _taxPercent = rs.getInt("taxPercent");
  594. _treasury = rs.getLong("treasury");
  595. _showNpcCrest = rs.getBoolean("showNpcCrest");
  596. _ticketBuyCount = rs.getInt("ticketBuyCount");
  597. }
  598. }
  599. _taxRate = _taxPercent / 100.0;
  600. ps2.setInt(1, getResidenceId());
  601. try (ResultSet rs = ps2.executeQuery())
  602. {
  603. while (rs.next())
  604. {
  605. _ownerId = rs.getInt("clan_id");
  606. }
  607. }
  608. }
  609. catch (Exception e)
  610. {
  611. _log.log(Level.WARNING, "Exception: loadCastleData(): " + e.getMessage(), e);
  612. }
  613. }
  614. /** Load All Functions */
  615. private void loadFunctions()
  616. {
  617. try (Connection con = L2DatabaseFactory.getInstance().getConnection();
  618. PreparedStatement ps = con.prepareStatement("SELECT * FROM castle_functions WHERE castle_id = ?"))
  619. {
  620. ps.setInt(1, getResidenceId());
  621. try (ResultSet rs = ps.executeQuery())
  622. {
  623. while (rs.next())
  624. {
  625. _function.put(rs.getInt("type"), new CastleFunction(rs.getInt("type"), rs.getInt("lvl"), rs.getInt("lease"), 0, rs.getLong("rate"), rs.getLong("endTime"), true));
  626. }
  627. }
  628. }
  629. catch (Exception e)
  630. {
  631. _log.log(Level.SEVERE, "Exception: Castle.loadFunctions(): " + e.getMessage(), e);
  632. }
  633. }
  634. /**
  635. * Remove function In List and in DB
  636. * @param functionType
  637. */
  638. public void removeFunction(int functionType)
  639. {
  640. _function.remove(functionType);
  641. try (Connection con = L2DatabaseFactory.getInstance().getConnection();
  642. PreparedStatement ps = con.prepareStatement("DELETE FROM castle_functions WHERE castle_id=? AND type=?"))
  643. {
  644. ps.setInt(1, getResidenceId());
  645. ps.setInt(2, functionType);
  646. ps.execute();
  647. }
  648. catch (Exception e)
  649. {
  650. _log.log(Level.SEVERE, "Exception: Castle.removeFunctions(int functionType): " + e.getMessage(), e);
  651. }
  652. }
  653. public boolean updateFunctions(L2PcInstance player, int type, int lvl, int lease, long rate, boolean addNew)
  654. {
  655. if (player == null)
  656. {
  657. return false;
  658. }
  659. if (lease > 0)
  660. {
  661. if (!player.destroyItemByItemId("Consume", Inventory.ADENA_ID, lease, null, true))
  662. {
  663. return false;
  664. }
  665. }
  666. if (addNew)
  667. {
  668. _function.put(type, new CastleFunction(type, lvl, lease, 0, rate, 0, false));
  669. }
  670. else
  671. {
  672. if ((lvl == 0) && (lease == 0))
  673. {
  674. removeFunction(type);
  675. }
  676. else
  677. {
  678. int diffLease = lease - _function.get(type).getLease();
  679. if (diffLease > 0)
  680. {
  681. _function.remove(type);
  682. _function.put(type, new CastleFunction(type, lvl, lease, 0, rate, -1, false));
  683. }
  684. else
  685. {
  686. _function.get(type).setLease(lease);
  687. _function.get(type).setLvl(lvl);
  688. _function.get(type).dbSave();
  689. }
  690. }
  691. }
  692. return true;
  693. }
  694. public void activateInstance()
  695. {
  696. loadDoor();
  697. }
  698. // This method loads castle door data from database
  699. private void loadDoor()
  700. {
  701. for (L2DoorInstance door : DoorTable.getInstance().getDoors())
  702. {
  703. if ((door.getCastle() != null) && (door.getCastle().getResidenceId() == getResidenceId()))
  704. {
  705. _doors.add(door);
  706. }
  707. }
  708. }
  709. // This method loads castle door upgrade data from database
  710. private void loadDoorUpgrade()
  711. {
  712. try (Connection con = L2DatabaseFactory.getInstance().getConnection();
  713. PreparedStatement ps = con.prepareStatement("SELECT * FROM castle_doorupgrade WHERE castleId=?"))
  714. {
  715. ps.setInt(1, getResidenceId());
  716. try (ResultSet rs = ps.executeQuery())
  717. {
  718. while (rs.next())
  719. {
  720. setDoorUpgrade(rs.getInt("doorId"), rs.getInt("ratio"), false);
  721. }
  722. }
  723. }
  724. catch (Exception e)
  725. {
  726. _log.log(Level.WARNING, "Exception: loadCastleDoorUpgrade(): " + e.getMessage(), e);
  727. }
  728. }
  729. private void removeDoorUpgrade()
  730. {
  731. for (L2DoorInstance door : _doors)
  732. {
  733. door.getStat().setUpgradeHpRatio(1);
  734. door.setCurrentHp(door.getCurrentHp());
  735. }
  736. try (Connection con = L2DatabaseFactory.getInstance().getConnection();
  737. PreparedStatement ps = con.prepareStatement("DELETE FROM castle_doorupgrade WHERE castleId=?"))
  738. {
  739. ps.setInt(1, getResidenceId());
  740. ps.execute();
  741. }
  742. catch (Exception e)
  743. {
  744. _log.log(Level.WARNING, "Exception: removeDoorUpgrade(): " + e.getMessage(), e);
  745. }
  746. }
  747. public void setDoorUpgrade(int doorId, int ratio, boolean save)
  748. {
  749. final L2DoorInstance door = (getDoors().isEmpty()) ? DoorTable.getInstance().getDoor(doorId) : getDoor(doorId);
  750. if (door == null)
  751. {
  752. return;
  753. }
  754. door.getStat().setUpgradeHpRatio(ratio);
  755. door.setCurrentHp(door.getMaxHp());
  756. if (save)
  757. {
  758. try (Connection con = L2DatabaseFactory.getInstance().getConnection();
  759. PreparedStatement ps = con.prepareStatement("REPLACE INTO castle_doorupgrade (doorId, ratio, castleId) values (?,?,?)"))
  760. {
  761. ps.setInt(1, doorId);
  762. ps.setInt(2, ratio);
  763. ps.setInt(3, getResidenceId());
  764. ps.execute();
  765. }
  766. catch (Exception e)
  767. {
  768. _log.log(Level.WARNING, "Exception: setDoorUpgrade(int doorId, int ratio, int castleId): " + e.getMessage(), e);
  769. }
  770. }
  771. }
  772. private void updateOwnerInDB(L2Clan clan)
  773. {
  774. if (clan != null)
  775. {
  776. _ownerId = clan.getId(); // Update owner id property
  777. }
  778. else
  779. {
  780. _ownerId = 0; // Remove owner
  781. CastleManorManager.getInstance().resetManorData(getResidenceId());
  782. }
  783. try (Connection con = L2DatabaseFactory.getInstance().getConnection())
  784. {
  785. // Need to remove has castle flag from clan_data, should be checked from castle table.
  786. try (PreparedStatement ps = con.prepareStatement("UPDATE clan_data SET hasCastle = 0 WHERE hasCastle = ?"))
  787. {
  788. ps.setInt(1, getResidenceId());
  789. ps.execute();
  790. }
  791. try (PreparedStatement ps = con.prepareStatement("UPDATE clan_data SET hasCastle = ? WHERE clan_id = ?"))
  792. {
  793. ps.setInt(1, getResidenceId());
  794. ps.setInt(2, getOwnerId());
  795. ps.execute();
  796. }
  797. // Announce to clan members
  798. if (clan != null)
  799. {
  800. clan.setCastleId(getResidenceId()); // Set has castle flag for new owner
  801. clan.broadcastToOnlineMembers(new PledgeShowInfoUpdate(clan));
  802. clan.broadcastToOnlineMembers(new PlaySound(1, "Siege_Victory", 0, 0, 0, 0, 0));
  803. }
  804. }
  805. catch (Exception e)
  806. {
  807. _log.log(Level.WARNING, "Exception: updateOwnerInDB(L2Clan clan): " + e.getMessage(), e);
  808. }
  809. }
  810. public final L2DoorInstance getDoor(int doorId)
  811. {
  812. if (doorId <= 0)
  813. {
  814. return null;
  815. }
  816. for (L2DoorInstance door : getDoors())
  817. {
  818. if (door.getId() == doorId)
  819. {
  820. return door;
  821. }
  822. }
  823. return null;
  824. }
  825. public final List<L2DoorInstance> getDoors()
  826. {
  827. return _doors;
  828. }
  829. public final int getOwnerId()
  830. {
  831. return _ownerId;
  832. }
  833. public final L2Clan getOwner()
  834. {
  835. return (_ownerId != 0) ? ClanTable.getInstance().getClan(_ownerId) : null;
  836. }
  837. public final Siege getSiege()
  838. {
  839. if (_siege == null)
  840. {
  841. _siege = new Siege(this);
  842. }
  843. return _siege;
  844. }
  845. public final Calendar getSiegeDate()
  846. {
  847. return _siegeDate;
  848. }
  849. public boolean getIsTimeRegistrationOver()
  850. {
  851. return _isTimeRegistrationOver;
  852. }
  853. public void setIsTimeRegistrationOver(boolean val)
  854. {
  855. _isTimeRegistrationOver = val;
  856. }
  857. public Calendar getTimeRegistrationOverDate()
  858. {
  859. if (_siegeTimeRegistrationEndDate == null)
  860. {
  861. _siegeTimeRegistrationEndDate = Calendar.getInstance();
  862. }
  863. return _siegeTimeRegistrationEndDate;
  864. }
  865. public final int getTaxPercent()
  866. {
  867. return _taxPercent;
  868. }
  869. public final double getTaxRate()
  870. {
  871. return _taxRate;
  872. }
  873. public final long getTreasury()
  874. {
  875. return _treasury;
  876. }
  877. public final boolean getShowNpcCrest()
  878. {
  879. return _showNpcCrest;
  880. }
  881. public final void setShowNpcCrest(boolean showNpcCrest)
  882. {
  883. if (_showNpcCrest != showNpcCrest)
  884. {
  885. _showNpcCrest = showNpcCrest;
  886. updateShowNpcCrest();
  887. }
  888. }
  889. public void updateClansReputation()
  890. {
  891. if (_formerOwner != null)
  892. {
  893. if (_formerOwner != ClanTable.getInstance().getClan(getOwnerId()))
  894. {
  895. int maxreward = Math.max(0, _formerOwner.getReputationScore());
  896. _formerOwner.takeReputationScore(Config.LOOSE_CASTLE_POINTS, true);
  897. L2Clan owner = ClanTable.getInstance().getClan(getOwnerId());
  898. if (owner != null)
  899. {
  900. owner.addReputationScore(Math.min(Config.TAKE_CASTLE_POINTS, maxreward), true);
  901. }
  902. }
  903. else
  904. {
  905. _formerOwner.addReputationScore(Config.CASTLE_DEFENDED_POINTS, true);
  906. }
  907. }
  908. else
  909. {
  910. L2Clan owner = ClanTable.getInstance().getClan(getOwnerId());
  911. if (owner != null)
  912. {
  913. owner.addReputationScore(Config.TAKE_CASTLE_POINTS, true);
  914. }
  915. }
  916. }
  917. public void updateShowNpcCrest()
  918. {
  919. try (Connection con = L2DatabaseFactory.getInstance().getConnection();
  920. PreparedStatement ps = con.prepareStatement("UPDATE castle SET showNpcCrest = ? WHERE id = ?"))
  921. {
  922. ps.setString(1, String.valueOf(getShowNpcCrest()));
  923. ps.setInt(2, getResidenceId());
  924. ps.execute();
  925. }
  926. catch (Exception e)
  927. {
  928. _log.info("Error saving showNpcCrest for castle " + getName() + ": " + e.getMessage());
  929. }
  930. }
  931. @Override
  932. public void giveResidentialSkills(L2PcInstance player)
  933. {
  934. Territory territory = TerritoryWarManager.getInstance().getTerritory(getResidenceId());
  935. if ((territory != null) && territory.getOwnedWardIds().contains(getResidenceId() + 80))
  936. {
  937. for (int wardId : territory.getOwnedWardIds())
  938. {
  939. final List<L2SkillLearn> territorySkills = SkillTreesData.getInstance().getAvailableResidentialSkills(wardId);
  940. for (L2SkillLearn s : territorySkills)
  941. {
  942. final Skill sk = SkillData.getInstance().getSkill(s.getSkillId(), s.getSkillLevel());
  943. if (sk != null)
  944. {
  945. player.addSkill(sk, false);
  946. }
  947. else
  948. {
  949. _log.warning("Trying to add a null skill for Territory Ward Id: " + wardId + ", skill Id: " + s.getSkillId() + " level: " + s.getSkillLevel() + "!");
  950. }
  951. }
  952. }
  953. }
  954. super.giveResidentialSkills(player);
  955. }
  956. @Override
  957. public void removeResidentialSkills(L2PcInstance player)
  958. {
  959. if (TerritoryWarManager.getInstance().getTerritory(getResidenceId()) != null)
  960. {
  961. for (int wardId : TerritoryWarManager.getInstance().getTerritory(getResidenceId()).getOwnedWardIds())
  962. {
  963. final List<L2SkillLearn> territorySkills = SkillTreesData.getInstance().getAvailableResidentialSkills(wardId);
  964. for (L2SkillLearn s : territorySkills)
  965. {
  966. final Skill sk = SkillData.getInstance().getSkill(s.getSkillId(), s.getSkillLevel());
  967. if (sk != null)
  968. {
  969. player.removeSkill(sk, false, true);
  970. }
  971. else
  972. {
  973. _log.warning("Trying to remove a null skill for Territory Ward Id: " + wardId + ", skill Id: " + s.getSkillId() + " level: " + s.getSkillLevel() + "!");
  974. }
  975. }
  976. }
  977. }
  978. super.removeResidentialSkills(player);
  979. }
  980. /**
  981. * Register Artefact to castle
  982. * @param artefact
  983. */
  984. public void registerArtefact(L2ArtefactInstance artefact)
  985. {
  986. _artefacts.add(artefact);
  987. }
  988. public List<L2ArtefactInstance> getArtefacts()
  989. {
  990. return _artefacts;
  991. }
  992. /**
  993. * @return the tickets exchanged for this castle
  994. */
  995. public int getTicketBuyCount()
  996. {
  997. return _ticketBuyCount;
  998. }
  999. /**
  1000. * Set the exchanged tickets count.<br>
  1001. * Performs database update.
  1002. * @param count the ticket count to set
  1003. */
  1004. public void setTicketBuyCount(int count)
  1005. {
  1006. _ticketBuyCount = count;
  1007. try (Connection con = L2DatabaseFactory.getInstance().getConnection();
  1008. PreparedStatement ps = con.prepareStatement("UPDATE castle SET ticketBuyCount = ? WHERE id = ?"))
  1009. {
  1010. ps.setInt(1, _ticketBuyCount);
  1011. ps.setInt(2, getResidenceId());
  1012. ps.execute();
  1013. }
  1014. catch (Exception e)
  1015. {
  1016. _log.log(Level.WARNING, e.getMessage(), e);
  1017. }
  1018. }
  1019. public int getTrapUpgradeLevel(int towerIndex)
  1020. {
  1021. final TowerSpawn spawn = SiegeManager.getInstance().getFlameTowers(getResidenceId()).get(towerIndex);
  1022. return (spawn != null) ? spawn.getUpgradeLevel() : 0;
  1023. }
  1024. public void setTrapUpgrade(int towerIndex, int level, boolean save)
  1025. {
  1026. if (save)
  1027. {
  1028. try (Connection con = L2DatabaseFactory.getInstance().getConnection();
  1029. PreparedStatement ps = con.prepareStatement("REPLACE INTO castle_trapupgrade (castleId, towerIndex, level) values (?,?,?)"))
  1030. {
  1031. ps.setInt(1, getResidenceId());
  1032. ps.setInt(2, towerIndex);
  1033. ps.setInt(3, level);
  1034. ps.execute();
  1035. }
  1036. catch (Exception e)
  1037. {
  1038. _log.log(Level.WARNING, "Exception: setTrapUpgradeLevel(int towerIndex, int level, int castleId): " + e.getMessage(), e);
  1039. }
  1040. }
  1041. final TowerSpawn spawn = SiegeManager.getInstance().getFlameTowers(getResidenceId()).get(towerIndex);
  1042. if (spawn != null)
  1043. {
  1044. spawn.setUpgradeLevel(level);
  1045. }
  1046. }
  1047. private void removeTrapUpgrade()
  1048. {
  1049. for (TowerSpawn ts : SiegeManager.getInstance().getFlameTowers(getResidenceId()))
  1050. {
  1051. ts.setUpgradeLevel(0);
  1052. }
  1053. try (Connection con = L2DatabaseFactory.getInstance().getConnection();
  1054. PreparedStatement ps = con.prepareStatement("DELETE FROM castle_trapupgrade WHERE castleId=?"))
  1055. {
  1056. ps.setInt(1, getResidenceId());
  1057. ps.execute();
  1058. }
  1059. catch (Exception e)
  1060. {
  1061. _log.log(Level.WARNING, "Exception: removeDoorUpgrade(): " + e.getMessage(), e);
  1062. }
  1063. }
  1064. @Override
  1065. protected void initResidenceZone()
  1066. {
  1067. for (L2CastleZone zone : ZoneManager.getInstance().getAllZones(L2CastleZone.class))
  1068. {
  1069. if (zone.getResidenceId() == getResidenceId())
  1070. {
  1071. setResidenceZone(zone);
  1072. break;
  1073. }
  1074. }
  1075. }
  1076. }