L2Party.java 31 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123
  1. /*
  2. * Copyright (C) 2004-2013 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;
  20. import java.util.ArrayList;
  21. import java.util.List;
  22. import java.util.NoSuchElementException;
  23. import java.util.concurrent.Future;
  24. import java.util.logging.Level;
  25. import java.util.logging.Logger;
  26. import javolution.util.FastList;
  27. import com.l2jserver.Config;
  28. import com.l2jserver.gameserver.GameTimeController;
  29. import com.l2jserver.gameserver.SevenSignsFestival;
  30. import com.l2jserver.gameserver.ThreadPoolManager;
  31. import com.l2jserver.gameserver.datatables.ItemTable;
  32. import com.l2jserver.gameserver.datatables.SkillTable;
  33. import com.l2jserver.gameserver.instancemanager.DuelManager;
  34. import com.l2jserver.gameserver.model.actor.L2Attackable;
  35. import com.l2jserver.gameserver.model.actor.L2Character;
  36. import com.l2jserver.gameserver.model.actor.L2Summon;
  37. import com.l2jserver.gameserver.model.actor.instance.L2PcInstance;
  38. import com.l2jserver.gameserver.model.actor.instance.L2ServitorInstance;
  39. import com.l2jserver.gameserver.model.entity.DimensionalRift;
  40. import com.l2jserver.gameserver.model.holders.ItemHolder;
  41. import com.l2jserver.gameserver.model.itemcontainer.PcInventory;
  42. import com.l2jserver.gameserver.model.items.instance.L2ItemInstance;
  43. import com.l2jserver.gameserver.model.skills.L2Skill;
  44. import com.l2jserver.gameserver.model.stats.Stats;
  45. import com.l2jserver.gameserver.network.SystemMessageId;
  46. import com.l2jserver.gameserver.network.serverpackets.ExAskModifyPartyLooting;
  47. import com.l2jserver.gameserver.network.serverpackets.ExCloseMPCC;
  48. import com.l2jserver.gameserver.network.serverpackets.ExOpenMPCC;
  49. import com.l2jserver.gameserver.network.serverpackets.ExPartyPetWindowAdd;
  50. import com.l2jserver.gameserver.network.serverpackets.ExPartyPetWindowDelete;
  51. import com.l2jserver.gameserver.network.serverpackets.ExSetPartyLooting;
  52. import com.l2jserver.gameserver.network.serverpackets.L2GameServerPacket;
  53. import com.l2jserver.gameserver.network.serverpackets.PartyMemberPosition;
  54. import com.l2jserver.gameserver.network.serverpackets.PartySmallWindowAdd;
  55. import com.l2jserver.gameserver.network.serverpackets.PartySmallWindowAll;
  56. import com.l2jserver.gameserver.network.serverpackets.PartySmallWindowDelete;
  57. import com.l2jserver.gameserver.network.serverpackets.PartySmallWindowDeleteAll;
  58. import com.l2jserver.gameserver.network.serverpackets.SystemMessage;
  59. import com.l2jserver.gameserver.util.Util;
  60. import com.l2jserver.util.Rnd;
  61. /**
  62. * This class serves as a container for player parties.
  63. * @author nuocnam
  64. */
  65. public class L2Party extends AbstractPlayerGroup
  66. {
  67. private static final Logger _log = Logger.getLogger(L2Party.class.getName());
  68. // @formatter:off
  69. private static final double[] BONUS_EXP_SP =
  70. {
  71. 1.0, 1.10, 1.20, 1.30, 1.40, 1.50, 2.0, 2.10, 2.20
  72. };
  73. // TODO: JIV - unhardcode to some SysString enum (sysstring-e.dat)
  74. private static final int[] LOOT_SYSSTRINGS =
  75. {
  76. 487, 488, 798, 799, 800
  77. };
  78. // @formatter:on
  79. private static final int PARTY_POSITION_BROADCAST_DELAY = 12000;
  80. public static final byte ITEM_LOOTER = 0;
  81. public static final byte ITEM_RANDOM = 1;
  82. public static final byte ITEM_RANDOM_SPOIL = 2;
  83. public static final byte ITEM_ORDER = 3;
  84. public static final byte ITEM_ORDER_SPOIL = 4;
  85. private final FastList<L2PcInstance> _members;
  86. private boolean _pendingInvitation = false;
  87. private long _pendingInviteTimeout;
  88. private int _partyLvl = 0;
  89. private int _itemDistribution = 0;
  90. private int _itemLastLoot = 0;
  91. private L2CommandChannel _commandChannel = null;
  92. private DimensionalRift _dr;
  93. private byte _requestChangeLoot = -1;
  94. private List<Integer> _changeLootAnswers = null;
  95. protected long _requestChangeLootTimer = 0;
  96. private Future<?> _checkTask = null;
  97. private Future<?> _positionBroadcastTask = null;
  98. protected PartyMemberPosition _positionPacket;
  99. private boolean _disbanding = false;
  100. /**
  101. * The message type send to the party members.
  102. */
  103. public enum messageType
  104. {
  105. Expelled,
  106. Left,
  107. None,
  108. Disconnected
  109. }
  110. /**
  111. * Construct a new L2Party object with a single member - the leader.
  112. * @param leader the leader of this party
  113. * @param itemDistribution the item distribution rule of this party
  114. */
  115. public L2Party(L2PcInstance leader, int itemDistribution)
  116. {
  117. _members = new FastList<L2PcInstance>().shared();
  118. _members.add(leader);
  119. _partyLvl = leader.getLevel();
  120. _itemDistribution = itemDistribution;
  121. }
  122. /**
  123. * Check if another player can start invitation process.
  124. * @return {@code true} if this party waits for a response on an invitation, {@code false} otherwise
  125. */
  126. public boolean getPendingInvitation()
  127. {
  128. return _pendingInvitation;
  129. }
  130. /**
  131. * Set invitation process flag and store time for expiration. <br>
  132. * Happens when a player joins party or declines to join.
  133. * @param val the pending invitation state to set
  134. */
  135. public void setPendingInvitation(boolean val)
  136. {
  137. _pendingInvitation = val;
  138. _pendingInviteTimeout = GameTimeController.getInstance().getGameTicks() + (L2PcInstance.REQUEST_TIMEOUT * GameTimeController.TICKS_PER_SECOND);
  139. }
  140. /**
  141. * Check if a player invitation request is expired.
  142. * @return {@code true} if time is expired, {@code false} otherwise
  143. * @see com.l2jserver.gameserver.model.actor.instance.L2PcInstance#isRequestExpired()
  144. */
  145. public boolean isInvitationRequestExpired()
  146. {
  147. return (_pendingInviteTimeout <= GameTimeController.getInstance().getGameTicks());
  148. }
  149. /**
  150. * Get a random member from this party.
  151. * @param itemId the ID of the item for which the member must have inventory space
  152. * @param target the object of which the member must be within a certain range (must not be null)
  153. * @return a random member from this party or {@code null} if none of the members have inventory space for the specified item
  154. */
  155. private L2PcInstance getCheckedRandomMember(int itemId, L2Character target)
  156. {
  157. List<L2PcInstance> availableMembers = new FastList<>();
  158. for (L2PcInstance member : getMembers())
  159. {
  160. if (member.getInventory().validateCapacityByItemId(itemId) && Util.checkIfInRange(Config.ALT_PARTY_RANGE2, target, member, true))
  161. {
  162. availableMembers.add(member);
  163. }
  164. }
  165. if (!availableMembers.isEmpty())
  166. {
  167. return availableMembers.get(Rnd.get(availableMembers.size()));
  168. }
  169. return null;
  170. }
  171. /**
  172. * get next item looter
  173. * @param ItemId
  174. * @param target
  175. * @return
  176. */
  177. private L2PcInstance getCheckedNextLooter(int ItemId, L2Character target)
  178. {
  179. for (int i = 0; i < getMemberCount(); i++)
  180. {
  181. if (++_itemLastLoot >= getMemberCount())
  182. {
  183. _itemLastLoot = 0;
  184. }
  185. L2PcInstance member;
  186. try
  187. {
  188. member = getMembers().get(_itemLastLoot);
  189. if (member.getInventory().validateCapacityByItemId(ItemId) && Util.checkIfInRange(Config.ALT_PARTY_RANGE2, target, member, true))
  190. {
  191. return member;
  192. }
  193. }
  194. catch (Exception e)
  195. {
  196. // continue, take another member if this just logged off
  197. }
  198. }
  199. return null;
  200. }
  201. /**
  202. * get next item looter
  203. * @param player
  204. * @param ItemId
  205. * @param spoil
  206. * @param target
  207. * @return
  208. */
  209. private L2PcInstance getActualLooter(L2PcInstance player, int ItemId, boolean spoil, L2Character target)
  210. {
  211. L2PcInstance looter = player;
  212. switch (_itemDistribution)
  213. {
  214. case ITEM_RANDOM:
  215. if (!spoil)
  216. {
  217. looter = getCheckedRandomMember(ItemId, target);
  218. }
  219. break;
  220. case ITEM_RANDOM_SPOIL:
  221. looter = getCheckedRandomMember(ItemId, target);
  222. break;
  223. case ITEM_ORDER:
  224. if (!spoil)
  225. {
  226. looter = getCheckedNextLooter(ItemId, target);
  227. }
  228. break;
  229. case ITEM_ORDER_SPOIL:
  230. looter = getCheckedNextLooter(ItemId, target);
  231. break;
  232. }
  233. if (looter == null)
  234. {
  235. looter = player;
  236. }
  237. return looter;
  238. }
  239. /**
  240. * Broadcasts UI update and User Info for new party leader.
  241. */
  242. public void broadcastToPartyMembersNewLeader()
  243. {
  244. for (L2PcInstance member : getMembers())
  245. {
  246. if (member != null)
  247. {
  248. member.sendPacket(PartySmallWindowDeleteAll.STATIC_PACKET);
  249. member.sendPacket(new PartySmallWindowAll(member, this));
  250. member.broadcastUserInfo();
  251. }
  252. }
  253. }
  254. /**
  255. * Send a Server->Client packet to all other L2PcInstance of the Party.<BR>
  256. * <BR>
  257. * @param player
  258. * @param msg
  259. */
  260. public void broadcastToPartyMembers(L2PcInstance player, L2GameServerPacket msg)
  261. {
  262. for (L2PcInstance member : getMembers())
  263. {
  264. if ((member != null) && (member.getObjectId() != player.getObjectId()))
  265. {
  266. member.sendPacket(msg);
  267. }
  268. }
  269. }
  270. /**
  271. * adds new member to party
  272. * @param player
  273. */
  274. public void addPartyMember(L2PcInstance player)
  275. {
  276. if (getMembers().contains(player))
  277. {
  278. return;
  279. }
  280. if (_requestChangeLoot != -1)
  281. {
  282. finishLootRequest(false); // cancel on invite
  283. }
  284. // sends new member party window for all members
  285. // we do all actions before adding member to a list, this speeds things up a little
  286. player.sendPacket(new PartySmallWindowAll(player, this));
  287. // sends pets/summons of party members
  288. for (L2PcInstance pMember : getMembers())
  289. {
  290. if ((pMember != null) && pMember.hasSummon())
  291. {
  292. player.sendPacket(new ExPartyPetWindowAdd(pMember.getSummon()));
  293. }
  294. }
  295. SystemMessage msg = SystemMessage.getSystemMessage(SystemMessageId.YOU_JOINED_S1_PARTY);
  296. msg.addString(getLeader().getName());
  297. player.sendPacket(msg);
  298. msg = SystemMessage.getSystemMessage(SystemMessageId.C1_JOINED_PARTY);
  299. msg.addString(player.getName());
  300. broadcastPacket(msg);
  301. broadcastPacket(new PartySmallWindowAdd(player, this));
  302. // send the position of all party members to the new party member
  303. // player.sendPacket(new PartyMemberPosition(this));
  304. // send the position of the new party member to all party members (except the new one - he knows his own position)
  305. // broadcastToPartyMembers(player, new PartyMemberPosition(this));
  306. // if member has pet/summon add it to other as well
  307. if (player.hasSummon())
  308. {
  309. broadcastPacket(new ExPartyPetWindowAdd(player.getSummon()));
  310. }
  311. // add player to party, adjust party level
  312. getMembers().add(player);
  313. if (player.getLevel() > _partyLvl)
  314. {
  315. _partyLvl = player.getLevel();
  316. }
  317. // update partySpelled
  318. L2Summon summon;
  319. for (L2PcInstance member : getMembers())
  320. {
  321. if (member != null)
  322. {
  323. member.updateEffectIcons(true); // update party icons only
  324. summon = member.getSummon();
  325. member.broadcastUserInfo();
  326. if (summon != null)
  327. {
  328. summon.updateEffectIcons();
  329. }
  330. }
  331. }
  332. if (isInDimensionalRift())
  333. {
  334. _dr.partyMemberInvited();
  335. }
  336. // open the CCInformationwindow
  337. if (isInCommandChannel())
  338. {
  339. player.sendPacket(ExOpenMPCC.STATIC_PACKET);
  340. }
  341. if (_positionBroadcastTask == null)
  342. {
  343. _positionBroadcastTask = ThreadPoolManager.getInstance().scheduleGeneralAtFixedRate(new PositionBroadcast(), PARTY_POSITION_BROADCAST_DELAY / 2, PARTY_POSITION_BROADCAST_DELAY);
  344. }
  345. }
  346. /**
  347. * Removes a party member using its name.
  348. * @param name player the player to be removed from the party.
  349. * @param type the message type {@link messageType}.
  350. */
  351. public void removePartyMember(String name, messageType type)
  352. {
  353. removePartyMember(getPlayerByName(name), type);
  354. }
  355. /**
  356. * Removes a party member instance.
  357. * @param player the player to be removed from the party.
  358. * @param type the message type {@link messageType}.
  359. */
  360. public void removePartyMember(L2PcInstance player, messageType type)
  361. {
  362. if (getMembers().contains(player))
  363. {
  364. final boolean isLeader = isLeader(player);
  365. if (!_disbanding)
  366. {
  367. if ((getMembers().size() == 2) || (isLeader && !Config.ALT_LEAVE_PARTY_LEADER && (type != messageType.Disconnected)))
  368. {
  369. disbandParty();
  370. return;
  371. }
  372. }
  373. getMembers().remove(player);
  374. recalculatePartyLevel();
  375. if (player.isFestivalParticipant())
  376. {
  377. SevenSignsFestival.getInstance().updateParticipants(player, this);
  378. }
  379. if (player.isInDuel())
  380. {
  381. DuelManager.getInstance().onRemoveFromParty(player);
  382. }
  383. try
  384. {
  385. if (player.getFusionSkill() != null)
  386. {
  387. player.abortCast();
  388. }
  389. for (L2Character character : player.getKnownList().getKnownCharacters())
  390. {
  391. if ((character.getFusionSkill() != null) && (character.getFusionSkill().getTarget() == player))
  392. {
  393. character.abortCast();
  394. }
  395. }
  396. }
  397. catch (Exception e)
  398. {
  399. _log.log(Level.WARNING, "", e);
  400. }
  401. SystemMessage msg;
  402. if (type == messageType.Expelled)
  403. {
  404. player.sendPacket(SystemMessageId.HAVE_BEEN_EXPELLED_FROM_PARTY);
  405. msg = SystemMessage.getSystemMessage(SystemMessageId.C1_WAS_EXPELLED_FROM_PARTY);
  406. msg.addString(player.getName());
  407. broadcastPacket(msg);
  408. }
  409. else if ((type == messageType.Left) || (type == messageType.Disconnected))
  410. {
  411. player.sendPacket(SystemMessageId.YOU_LEFT_PARTY);
  412. msg = SystemMessage.getSystemMessage(SystemMessageId.C1_LEFT_PARTY);
  413. msg.addString(player.getName());
  414. broadcastPacket(msg);
  415. }
  416. // UI update.
  417. player.sendPacket(PartySmallWindowDeleteAll.STATIC_PACKET);
  418. player.setParty(null);
  419. broadcastPacket(new PartySmallWindowDelete(player));
  420. if (player.hasSummon())
  421. {
  422. broadcastPacket(new ExPartyPetWindowDelete(player.getSummon()));
  423. }
  424. if (isInDimensionalRift())
  425. {
  426. _dr.partyMemberExited(player);
  427. }
  428. // Close the CCInfoWindow
  429. if (isInCommandChannel())
  430. {
  431. player.sendPacket(new ExCloseMPCC());
  432. }
  433. if (isLeader && (getMembers().size() > 1) && (Config.ALT_LEAVE_PARTY_LEADER || (type == messageType.Disconnected)))
  434. {
  435. msg = SystemMessage.getSystemMessage(SystemMessageId.C1_HAS_BECOME_A_PARTY_LEADER);
  436. msg.addString(getLeader().getName());
  437. broadcastPacket(msg);
  438. broadcastToPartyMembersNewLeader();
  439. }
  440. else if (getMembers().size() == 1)
  441. {
  442. if (isInCommandChannel())
  443. {
  444. // delete the whole command channel when the party who opened the channel is disbanded
  445. if (getCommandChannel().getLeader().getObjectId() == getLeader().getObjectId())
  446. {
  447. getCommandChannel().disbandChannel();
  448. }
  449. else
  450. {
  451. getCommandChannel().removeParty(this);
  452. }
  453. }
  454. if (getLeader() != null)
  455. {
  456. getLeader().setParty(null);
  457. if (getLeader().isInDuel())
  458. {
  459. DuelManager.getInstance().onRemoveFromParty(getLeader());
  460. }
  461. }
  462. if (_checkTask != null)
  463. {
  464. _checkTask.cancel(true);
  465. _checkTask = null;
  466. }
  467. if (_positionBroadcastTask != null)
  468. {
  469. _positionBroadcastTask.cancel(false);
  470. _positionBroadcastTask = null;
  471. }
  472. _members.clear();
  473. }
  474. }
  475. }
  476. /**
  477. * Disperse a party and send a message to all its members.
  478. */
  479. public void disbandParty()
  480. {
  481. _disbanding = true;
  482. if (_members != null)
  483. {
  484. broadcastPacket(SystemMessage.getSystemMessage(SystemMessageId.PARTY_DISPERSED));
  485. for (L2PcInstance member : _members)
  486. {
  487. if (member != null)
  488. {
  489. removePartyMember(member, messageType.None);
  490. }
  491. }
  492. }
  493. }
  494. /**
  495. * Change party leader (used for string arguments)
  496. * @param name the name of the player to set as the new party leader
  497. */
  498. public void changePartyLeader(String name)
  499. {
  500. setLeader(getPlayerByName(name));
  501. }
  502. @Override
  503. public void setLeader(L2PcInstance player)
  504. {
  505. if ((player != null) && !player.isInDuel())
  506. {
  507. if (getMembers().contains(player))
  508. {
  509. if (isLeader(player))
  510. {
  511. player.sendPacket(SystemMessageId.YOU_CANNOT_TRANSFER_RIGHTS_TO_YOURSELF);
  512. }
  513. else
  514. {
  515. // Swap party members
  516. L2PcInstance temp = getLeader();
  517. int p1 = getMembers().indexOf(player);
  518. getMembers().set(0, player);
  519. getMembers().set(p1, temp);
  520. SystemMessage msg = SystemMessage.getSystemMessage(SystemMessageId.C1_HAS_BECOME_A_PARTY_LEADER);
  521. msg.addString(getLeader().getName());
  522. broadcastPacket(msg);
  523. broadcastToPartyMembersNewLeader();
  524. if (isInCommandChannel() && _commandChannel.isLeader(temp))
  525. {
  526. _commandChannel.setLeader(getLeader());
  527. msg = SystemMessage.getSystemMessage(SystemMessageId.COMMAND_CHANNEL_LEADER_NOW_C1);
  528. msg.addString(_commandChannel.getLeader().getName());
  529. _commandChannel.broadcastPacket(msg);
  530. }
  531. if (player.isInPartyMatchRoom())
  532. {
  533. PartyMatchRoom room = PartyMatchRoomList.getInstance().getPlayerRoom(player);
  534. room.changeLeader(player);
  535. }
  536. }
  537. }
  538. else
  539. {
  540. player.sendPacket(SystemMessageId.YOU_CAN_TRANSFER_RIGHTS_ONLY_TO_ANOTHER_PARTY_MEMBER);
  541. }
  542. }
  543. }
  544. /**
  545. * finds a player in the party by name
  546. * @param name
  547. * @return
  548. */
  549. private L2PcInstance getPlayerByName(String name)
  550. {
  551. for (L2PcInstance member : getMembers())
  552. {
  553. if (member.getName().equalsIgnoreCase(name))
  554. {
  555. return member;
  556. }
  557. }
  558. return null;
  559. }
  560. /**
  561. * distribute item(s) to party members
  562. * @param player
  563. * @param item
  564. */
  565. public void distributeItem(L2PcInstance player, L2ItemInstance item)
  566. {
  567. if (item.getItemId() == PcInventory.ADENA_ID)
  568. {
  569. distributeAdena(player, item.getCount(), player);
  570. ItemTable.getInstance().destroyItem("Party", item, player, null);
  571. return;
  572. }
  573. L2PcInstance target = getActualLooter(player, item.getItemId(), false, player);
  574. target.addItem("Party", item, player, true);
  575. // Send messages to other party members about reward
  576. if (item.getCount() > 1)
  577. {
  578. SystemMessage msg = SystemMessage.getSystemMessage(SystemMessageId.C1_OBTAINED_S3_S2);
  579. msg.addString(target.getName());
  580. msg.addItemName(item);
  581. msg.addItemNumber(item.getCount());
  582. broadcastToPartyMembers(target, msg);
  583. }
  584. else
  585. {
  586. SystemMessage msg = SystemMessage.getSystemMessage(SystemMessageId.C1_OBTAINED_S2);
  587. msg.addString(target.getName());
  588. msg.addItemName(item);
  589. broadcastToPartyMembers(target, msg);
  590. }
  591. }
  592. /**
  593. * distribute item(s) to party members
  594. * @param player
  595. * @param item
  596. * @param spoil
  597. * @param target
  598. */
  599. public void distributeItem(L2PcInstance player, ItemHolder item, boolean spoil, L2Attackable target)
  600. {
  601. if (item == null)
  602. {
  603. return;
  604. }
  605. if (item.getId() == PcInventory.ADENA_ID)
  606. {
  607. distributeAdena(player, item.getCount(), target);
  608. return;
  609. }
  610. L2PcInstance looter = getActualLooter(player, item.getId(), spoil, target);
  611. looter.addItem(spoil ? "Sweeper" : "Party", item, player, true);
  612. // Send messages to other party members about reward
  613. if (item.getCount() > 1)
  614. {
  615. SystemMessage msg = spoil ? SystemMessage.getSystemMessage(SystemMessageId.C1_SWEEPED_UP_S3_S2) : SystemMessage.getSystemMessage(SystemMessageId.C1_OBTAINED_S3_S2);
  616. msg.addString(looter.getName());
  617. msg.addItemName(item.getId());
  618. msg.addItemNumber(item.getCount());
  619. broadcastToPartyMembers(looter, msg);
  620. }
  621. else
  622. {
  623. SystemMessage msg = spoil ? SystemMessage.getSystemMessage(SystemMessageId.C1_SWEEPED_UP_S2) : SystemMessage.getSystemMessage(SystemMessageId.C1_OBTAINED_S2);
  624. msg.addString(looter.getName());
  625. msg.addItemName(item.getId());
  626. broadcastToPartyMembers(looter, msg);
  627. }
  628. }
  629. /**
  630. * distribute adena to party members
  631. * @param player
  632. * @param adena
  633. * @param target
  634. */
  635. public void distributeAdena(L2PcInstance player, long adena, L2Character target)
  636. {
  637. // Get all the party members
  638. List<L2PcInstance> membersList = getMembers();
  639. // Check the number of party members that must be rewarded
  640. // (The party member must be in range to receive its reward)
  641. List<L2PcInstance> ToReward = FastList.newInstance();
  642. for (L2PcInstance member : membersList)
  643. {
  644. if (!Util.checkIfInRange(Config.ALT_PARTY_RANGE2, target, member, true))
  645. {
  646. continue;
  647. }
  648. ToReward.add(member);
  649. }
  650. // Avoid null exceptions, if any
  651. if (ToReward.isEmpty())
  652. {
  653. return;
  654. }
  655. // Now we can actually distribute the adena reward
  656. // (Total adena splitted by the number of party members that are in range and must be rewarded)
  657. long count = adena / ToReward.size();
  658. for (L2PcInstance member : ToReward)
  659. {
  660. member.addAdena("Party", count, player, true);
  661. }
  662. FastList.recycle((FastList<?>) ToReward);
  663. }
  664. /**
  665. * Distribute Experience and SP rewards to L2PcInstance Party members in the known area of the last attacker.<BR>
  666. * <BR>
  667. * <B><U> Actions</U> :</B> <li>Get the L2PcInstance owner of the L2ServitorInstance (if necessary)</li> <li>Calculate the Experience and SP reward distribution rate</li> <li>Add Experience and SP to the L2PcInstance</li><BR>
  668. * @param xpReward The Experience reward to distribute
  669. * @param spReward The SP reward to distribute
  670. * @param rewardedMembers The list of L2PcInstance to reward
  671. * @param topLvl
  672. * @param partyDmg
  673. * @param target
  674. */
  675. public void distributeXpAndSp(long xpReward, int spReward, List<L2PcInstance> rewardedMembers, int topLvl, int partyDmg, L2Attackable target)
  676. {
  677. final List<L2PcInstance> validMembers = getValidMembers(rewardedMembers, topLvl);
  678. xpReward *= getExpBonus(validMembers.size());
  679. spReward *= getSpBonus(validMembers.size());
  680. int sqLevelSum = 0;
  681. for (L2PcInstance member : validMembers)
  682. {
  683. sqLevelSum += (member.getLevel() * member.getLevel());
  684. }
  685. final float vitalityPoints = (target.getVitalityPoints(partyDmg) * Config.RATE_PARTY_XP) / validMembers.size();
  686. final boolean useVitalityRate = target.useVitalityRate();
  687. for (L2PcInstance member : rewardedMembers)
  688. {
  689. if (member.isDead())
  690. {
  691. continue;
  692. }
  693. // Calculate and add the EXP and SP reward to the member
  694. if (validMembers.contains(member))
  695. {
  696. // The servitor penalty
  697. final float penalty = member.hasServitor() ? ((L2ServitorInstance) member.getSummon()).getExpPenalty() : 0;
  698. final double sqLevel = member.getLevel() * member.getLevel();
  699. final double preCalculation = (sqLevel / sqLevelSum) * (1 - penalty);
  700. // Add the XP/SP points to the requested party member
  701. long addexp = Math.round(member.calcStat(Stats.EXPSP_RATE, xpReward * preCalculation, null, null));
  702. int addsp = (int) member.calcStat(Stats.EXPSP_RATE, spReward * preCalculation, null, null);
  703. addexp = calculateExpSpPartyCutoff(member.getActingPlayer(), topLvl, addexp, addsp, useVitalityRate);
  704. // TODO: unhardcode me?
  705. final int skillLvl = member.getActingPlayer().getSkillLevel(467);
  706. if (skillLvl > 0)
  707. {
  708. final L2Skill skill = SkillTable.getInstance().getInfo(467, skillLvl);
  709. if (skill.getExpNeeded() <= addexp)
  710. {
  711. member.absorbSoul(skill, target);
  712. }
  713. }
  714. if (addexp > 0)
  715. {
  716. member.updateVitalityPoints(vitalityPoints, true, false);
  717. }
  718. }
  719. else
  720. {
  721. member.addExpAndSp(0, 0);
  722. }
  723. }
  724. }
  725. private final long calculateExpSpPartyCutoff(L2PcInstance player, int topLvl, long addExp, int addSp, boolean vit)
  726. {
  727. long xp = addExp;
  728. int sp = addSp;
  729. if (Config.PARTY_XP_CUTOFF_METHOD.equalsIgnoreCase("highfive"))
  730. {
  731. int i = 0;
  732. final int lvlDiff = topLvl - player.getLevel();
  733. for (int[] gap : Config.PARTY_XP_CUTOFF_GAPS)
  734. {
  735. if ((lvlDiff >= gap[0]) && (lvlDiff <= gap[1]))
  736. {
  737. xp = (addExp * Config.PARTY_XP_CUTOFF_GAP_PERCENTS[i]) / 100;
  738. sp = (addSp * Config.PARTY_XP_CUTOFF_GAP_PERCENTS[i]) / 100;
  739. player.addExpAndSp(xp, sp, vit);
  740. break;
  741. }
  742. i++;
  743. }
  744. }
  745. else
  746. {
  747. player.addExpAndSp(addExp, addSp, vit);
  748. }
  749. return xp;
  750. }
  751. /**
  752. * refresh party level
  753. */
  754. public void recalculatePartyLevel()
  755. {
  756. int newLevel = 0;
  757. for (L2PcInstance member : getMembers())
  758. {
  759. if (member == null)
  760. {
  761. getMembers().remove(member);
  762. continue;
  763. }
  764. if (member.getLevel() > newLevel)
  765. {
  766. newLevel = member.getLevel();
  767. }
  768. }
  769. _partyLvl = newLevel;
  770. }
  771. private List<L2PcInstance> getValidMembers(List<L2PcInstance> members, int topLvl)
  772. {
  773. final List<L2PcInstance> validMembers = new ArrayList<>();
  774. // Fixed LevelDiff cutoff point
  775. if (Config.PARTY_XP_CUTOFF_METHOD.equalsIgnoreCase("level"))
  776. {
  777. for (L2PcInstance member : members)
  778. {
  779. if ((topLvl - member.getLevel()) <= Config.PARTY_XP_CUTOFF_LEVEL)
  780. {
  781. validMembers.add(member);
  782. }
  783. }
  784. }
  785. // Fixed MinPercentage cutoff point
  786. else if (Config.PARTY_XP_CUTOFF_METHOD.equalsIgnoreCase("percentage"))
  787. {
  788. int sqLevelSum = 0;
  789. for (L2PcInstance member : members)
  790. {
  791. sqLevelSum += (member.getLevel() * member.getLevel());
  792. }
  793. for (L2PcInstance member : members)
  794. {
  795. int sqLevel = member.getLevel() * member.getLevel();
  796. if ((sqLevel * 100) >= (sqLevelSum * Config.PARTY_XP_CUTOFF_PERCENT))
  797. {
  798. validMembers.add(member);
  799. }
  800. }
  801. }
  802. // Automatic cutoff method
  803. else if (Config.PARTY_XP_CUTOFF_METHOD.equalsIgnoreCase("auto"))
  804. {
  805. int sqLevelSum = 0;
  806. for (L2PcInstance member : members)
  807. {
  808. sqLevelSum += (member.getLevel() * member.getLevel());
  809. }
  810. int i = members.size() - 1;
  811. if (i < 1)
  812. {
  813. return members;
  814. }
  815. if (i >= BONUS_EXP_SP.length)
  816. {
  817. i = BONUS_EXP_SP.length - 1;
  818. }
  819. for (L2PcInstance member : members)
  820. {
  821. int sqLevel = member.getLevel() * member.getLevel();
  822. if (sqLevel >= (sqLevelSum / (members.size() * members.size())))
  823. {
  824. validMembers.add(member);
  825. }
  826. }
  827. }
  828. // High Five cutoff method
  829. else if (Config.PARTY_XP_CUTOFF_METHOD.equalsIgnoreCase("highfive"))
  830. {
  831. validMembers.addAll(members);
  832. }
  833. else if (Config.PARTY_XP_CUTOFF_METHOD.equalsIgnoreCase("none"))
  834. {
  835. validMembers.addAll(members);
  836. }
  837. return validMembers;
  838. }
  839. private double getBaseExpSpBonus(int membersCount)
  840. {
  841. int i = membersCount - 1;
  842. if (i < 1)
  843. {
  844. return 1;
  845. }
  846. if (i >= BONUS_EXP_SP.length)
  847. {
  848. i = BONUS_EXP_SP.length - 1;
  849. }
  850. return BONUS_EXP_SP[i];
  851. }
  852. private double getExpBonus(int membersCount)
  853. {
  854. return (membersCount < 2) ? (getBaseExpSpBonus(membersCount)) : (getBaseExpSpBonus(membersCount) * Config.RATE_PARTY_XP);
  855. }
  856. private double getSpBonus(int membersCount)
  857. {
  858. return (membersCount < 2) ? (getBaseExpSpBonus(membersCount)) : (getBaseExpSpBonus(membersCount) * Config.RATE_PARTY_SP);
  859. }
  860. @Override
  861. public int getLevel()
  862. {
  863. return _partyLvl;
  864. }
  865. public int getLootDistribution()
  866. {
  867. return _itemDistribution;
  868. }
  869. public boolean isInCommandChannel()
  870. {
  871. return _commandChannel != null;
  872. }
  873. public L2CommandChannel getCommandChannel()
  874. {
  875. return _commandChannel;
  876. }
  877. public void setCommandChannel(L2CommandChannel channel)
  878. {
  879. _commandChannel = channel;
  880. }
  881. public boolean isInDimensionalRift()
  882. {
  883. return _dr != null;
  884. }
  885. public void setDimensionalRift(DimensionalRift dr)
  886. {
  887. _dr = dr;
  888. }
  889. public DimensionalRift getDimensionalRift()
  890. {
  891. return _dr;
  892. }
  893. /**
  894. * @return the leader of this party
  895. */
  896. @Override
  897. public L2PcInstance getLeader()
  898. {
  899. try
  900. {
  901. return _members.getFirst();
  902. }
  903. catch (NoSuchElementException e)
  904. {
  905. return null;
  906. }
  907. }
  908. public void requestLootChange(byte type)
  909. {
  910. if (_requestChangeLoot != -1)
  911. {
  912. if (System.currentTimeMillis() > _requestChangeLootTimer)
  913. {
  914. finishLootRequest(false); // timeout 45sec, guess
  915. }
  916. else
  917. {
  918. return;
  919. }
  920. }
  921. _requestChangeLoot = type;
  922. int additionalTime = L2PcInstance.REQUEST_TIMEOUT * 3000;
  923. _requestChangeLootTimer = System.currentTimeMillis() + additionalTime;
  924. _changeLootAnswers = FastList.newInstance();
  925. _checkTask = ThreadPoolManager.getInstance().scheduleGeneralAtFixedRate(new ChangeLootCheck(), additionalTime + 1000, 5000);
  926. broadcastToPartyMembers(getLeader(), new ExAskModifyPartyLooting(getLeader().getName(), type));
  927. SystemMessage sm = SystemMessage.getSystemMessage(SystemMessageId.REQUESTING_APPROVAL_CHANGE_PARTY_LOOT_S1);
  928. sm.addSystemString(LOOT_SYSSTRINGS[type]);
  929. getLeader().sendPacket(sm);
  930. }
  931. public synchronized void answerLootChangeRequest(L2PcInstance member, boolean answer)
  932. {
  933. if (_requestChangeLoot == -1)
  934. {
  935. return;
  936. }
  937. if (_changeLootAnswers.contains(member.getObjectId()))
  938. {
  939. return;
  940. }
  941. if (!answer)
  942. {
  943. finishLootRequest(false);
  944. return;
  945. }
  946. _changeLootAnswers.add(member.getObjectId());
  947. if (_changeLootAnswers.size() >= (getMemberCount() - 1))
  948. {
  949. finishLootRequest(true);
  950. }
  951. }
  952. protected synchronized void finishLootRequest(boolean success)
  953. {
  954. if (_requestChangeLoot == -1)
  955. {
  956. return;
  957. }
  958. if (_checkTask != null)
  959. {
  960. _checkTask.cancel(false);
  961. _checkTask = null;
  962. }
  963. if (success)
  964. {
  965. broadcastPacket(new ExSetPartyLooting(1, _requestChangeLoot));
  966. _itemDistribution = _requestChangeLoot;
  967. SystemMessage sm = SystemMessage.getSystemMessage(SystemMessageId.PARTY_LOOT_CHANGED_S1);
  968. sm.addSystemString(LOOT_SYSSTRINGS[_requestChangeLoot]);
  969. broadcastPacket(sm);
  970. }
  971. else
  972. {
  973. broadcastPacket(new ExSetPartyLooting(0, (byte) 0));
  974. broadcastPacket(SystemMessage.getSystemMessage(SystemMessageId.PARTY_LOOT_CHANGE_CANCELLED));
  975. }
  976. _requestChangeLoot = -1;
  977. FastList.recycle((FastList<?>) _changeLootAnswers);
  978. _requestChangeLootTimer = 0;
  979. }
  980. protected class ChangeLootCheck implements Runnable
  981. {
  982. @Override
  983. public void run()
  984. {
  985. if (System.currentTimeMillis() > _requestChangeLootTimer)
  986. {
  987. finishLootRequest(false);
  988. }
  989. }
  990. }
  991. protected class PositionBroadcast implements Runnable
  992. {
  993. @Override
  994. public void run()
  995. {
  996. if (_positionPacket == null)
  997. {
  998. _positionPacket = new PartyMemberPosition(L2Party.this);
  999. }
  1000. else
  1001. {
  1002. _positionPacket.reuse(L2Party.this);
  1003. }
  1004. broadcastPacket(_positionPacket);
  1005. }
  1006. }
  1007. /**
  1008. * @return a list of all members of this party
  1009. */
  1010. @Override
  1011. public List<L2PcInstance> getMembers()
  1012. {
  1013. return _members;
  1014. }
  1015. /**
  1016. * Check whether the leader of this party is the same as the leader of the specified party (which essentially means they're the same group).
  1017. * @param party the other party to check against
  1018. * @return {@code true} if this party equals the specified party, {@code false} otherwise
  1019. */
  1020. public boolean equals(L2Party party)
  1021. {
  1022. return (party != null) && (getLeaderObjectId() == party.getLeaderObjectId());
  1023. }
  1024. }