Files
sweetgum-server/src/main/java/net/server/channel/handlers/RaiseIncExpHandler.java
2021-09-09 23:26:02 +02:00

73 lines
2.6 KiB
Java

package net.server.channel.handlers;
import client.Character;
import client.Client;
import client.QuestStatus;
import client.inventory.Inventory;
import client.inventory.InventoryType;
import client.inventory.manipulator.InventoryManipulator;
import net.AbstractPacketHandler;
import net.packet.InPacket;
import server.ItemInformationProvider;
import server.ItemInformationProvider.QuestConsItem;
import server.quest.Quest;
import tools.PacketCreator;
import java.util.Map;
/**
* @author Xari
* @author Ronan - added concurrency protection and quest progress limit
*/
public class RaiseIncExpHandler extends AbstractPacketHandler {
@Override
public final void handlePacket(InPacket p, Client c) {
byte inventorytype = p.readByte();//nItemIT
short slot = p.readShort();//nSlotPosition
int itemid = p.readInt();//nItemID
if (c.tryacquireClient()) {
try {
ItemInformationProvider ii = ItemInformationProvider.getInstance();
QuestConsItem consItem = ii.getQuestConsumablesInfo(itemid);
if (consItem == null) {
return;
}
int infoNumber = consItem.questid;
Map<Integer, Integer> consumables = consItem.items;
Character chr = c.getPlayer();
Quest quest = Quest.getInstanceFromInfoNumber(infoNumber);
if (!chr.getQuest(quest).getStatus().equals(QuestStatus.Status.STARTED)) {
c.sendPacket(PacketCreator.enableActions());
return;
}
int consId;
Inventory inv = chr.getInventory(InventoryType.getByType(inventorytype));
inv.lockInventory();
try {
consId = inv.getItem(slot).getItemId();
if (!consumables.containsKey(consId) || !chr.haveItem(consId)) {
return;
}
InventoryManipulator.removeFromSlot(c, InventoryType.getByType(inventorytype), slot, (short) 1, false, true);
} finally {
inv.unlockInventory();
}
int questid = quest.getId();
int nextValue = Math.min(consumables.get(consId) + c.getAbstractPlayerInteraction().getQuestProgressInt(questid, infoNumber), consItem.exp * consItem.grade);
c.getAbstractPlayerInteraction().setQuestProgress(questid, infoNumber, nextValue);
c.sendPacket(PacketCreator.enableActions());
} finally {
c.releaseClient();
}
}
}
}