Ингеймшопа

[JND]

Как исправить данную проблему?

[ALeKsIuS]

Может денег акку прописать? нэ?

[JND]

Все прописано

[ALeKsIuS]

Смотрите сервис, там запросы жестокие

[ReaM]

задонатить 1 монету

[marti-nfalse]

пакетку проверить просмотреть. что на вывод средств
сервис просмотреть и перепроверить дао -_-

[ALeKsIuS]

Достаточно запросы подправить в сервисе.

[marti-nfalse]

очень интимный вопрос, что это за сборка то такая ? помимо запроса могут быть ошибки и по другим пунктам (не исключать); + мало кто ответит\ рассуждая лиш по скриншоту =)

[ALeKsIuS]

Сервис:

Свернуть ↑

package com.mir.gameserver.services;

import com.jamie.commons.database.DatabaseFactory;
import com.jamie.commons.database.dao.DAOManager;
import com.mir.gameserver.configs.network.NetworkConfig;
import com.mir.gameserver.dao.PlayerDAO;
import com.mir.gameserver.model.gameobjects.player.Player;
import com.mir.gameserver.model.gameobjects.player.PlayerCommonData;
import com.mir.gameserver.network.aion.serverpackets.SM_SYSTEM_MESSAGE;
import com.mir.gameserver.utils.PacketSendUtility;
import org.apache.log4j.Logger;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.HashMap;

/**
 * @author Made in Russia.
 *
 */
public class CashShopManager
{
	private static final Logger	log	= Logger.getLogger(CashShopManager.class);
	private static CashShopManager instance;
	public HashMap<Integer, ShopCategory> categories = new HashMap<Integer, ShopCategory>();
	private ShopItem[] rankItems;
	public class ShopCategory
	{
		public int id;
		public String name;
		public HashMap<Integer, ShopItem> items = new HashMap<Integer, ShopItem>();

		public ShopCategory(int id)
		{
			this.id = id;
		}
	}

	public class ShopItem
	{
		public int id;
		public int itemId;
		public int count;
		public long price;
		public String name;
		public String desc = "";
		public int	eyecatch;

		public ShopItem(int id)
		{
			this.id = id;
		}
	}

	public static CashShopManager getInstance()
	{
		if(instance == null)
			instance = new CashShopManager();
		return instance;
	}

	public CashShopManager()
	{
		// TODO : Relocate the DAO
		
		log.info("Loading ingame shop...");
		
		// The first category (id 1) display all the items. Any additionnal category must be id 2 and +
		@SuppressWarnings("unused")
		int catId = 1;
		@SuppressWarnings("unused")
		int itId = 0;

		Connection con = null;

		try
		{
			con = DatabaseFactory.getConnection();
			PreparedStatement stmt = con.prepareStatement("SELECT * FROM aionshop_categories");
			ResultSet catRs = stmt.executeQuery();
			while(catRs.next())
			{
				ShopCategory cat = new ShopCategory(catRs.getInt("categoryId"));
				cat.name = catRs.getString("categoryName");
				
				PreparedStatement stmt2 = con.prepareStatement("SELECT * FROM aionshop_items WHERE itemCategory = ?");
				stmt2.setInt(1, cat.id);
				ResultSet rs2 = stmt2.executeQuery();
				
				while(rs2.next())
				{
					ShopItem item = new ShopItem(rs2.getInt("itemUniqueId"));
					item.itemId = rs2.getInt("itemTemplateId");
					item.count = rs2.getInt("itemCount");
					item.price = rs2.getInt("itemPrice");
					item.name = rs2.getString("itemName");
					item.desc = rs2.getString("itemDesc");
					item.eyecatch = rs2.getInt("itemEyecatch");
					cat.items.put(item.id, item);
				}
				
				rs2.close();
				stmt2.close();

				categories.put(cat.id, cat);				
			}

			catRs.close();
			stmt.close();
			con.close();
			
		}
		catch(Exception e)
		{
			log.error("Cannot load ingame shop contents !", e);
		}
		finally
		{
			DatabaseFactory.close(con);
		}
		rankItems = getRankItemsFromDB();
		log.info("Loaded " + getAllItems().length +" items.");
	}

	public int getItemsCount()
	{
		return getAllItems().length;
	}

	public int getItemsCount(int catId)
	{
		return getItems(catId).length;
	}

	public ShopItem getItem(int id)
	{
		for(ShopCategory category : categories.values())
			if(category.items.containsKey(id))
				return category.items.get(id);
		return null;
	}

	public ShopItem[] getAllItems()
	{
		ArrayList<ShopItem> res = new ArrayList<ShopItem>();
		for(ShopCategory category : categories.values())
			res.addAll(category.items.values());
		return res.toArray(new ShopItem[res.size()]);
	}

	public ShopItem[] getItems(int catId)
	{
		if(catId == 1)
			return getAllItems();
		ShopCategory category = categories.get(catId);
		if(category == null)
			return new ShopItem[0];
		return category.items.values().toArray(new ShopItem[category.items.size()]);
	}

	public ShopItem[] getItems(int catId, int page)
	{
		ShopItem[] list = getItems(catId);
		ShopItem[] res = new ShopItem[9];
		int n = 0;
		for(int i = page * 9; i < (page + 1) * 9; i++)
		{
			if(i < list.length)
			{
				res[n] = list[i];
				n++;
			}
			else
				break;
		}
		if(n != 9)
			res = compact(res, n);
		return res;
	}

	private ShopItem[] compact(ShopItem[] items, int size)
	{
		ShopItem[] new_items = new ShopItem[size];
		System.arraycopy(items, 0, new_items, 0, size);
		return new_items;
	}

	public ShopCategory[] getCategories()
	{
		return categories.values().toArray(new ShopCategory[categories.size()]);
	}

	public void buyItem(Player player, int id, int count)
	{
		ShopItem item = getItem(id);
		
		if(item == null)
		{
			// You have failed to purchase the item.
			PacketSendUtility.sendPacket(player, new SM_SYSTEM_MESSAGE(1400105));
			return;
		}
		if(player.getShopMoney() < item.price)
		{
			// You do not have enough Cash Points.
			PacketSendUtility.sendPacket(player, new SM_SYSTEM_MESSAGE(1400108));
			return;
		}
		
		ItemService.addItem(player, item.itemId, item.count);

		decreaseAndUpdate(player, item.price);

		logPurchase(player, item.itemId);		
	}
	
	void decreaseAndUpdate(Player player, long value)
	{
		/**
		 * param value : the credits spent
		 * 
		 * Add your own code before sending credit update packet if you need.
		 * PacketSendUtility.sendPacket(player, new SM_INGAMESHOP_BALANCE());
		 * 
		 */
		decreaseCredits(player, value);
	}
	
	void increaseAndUpdate(Player player, long value)
	{
		increaseCredits(player, value);
	}
	
	public void giftItem(Player player, int id, int count, String receiver, String message)
	{
		ShopItem item = getItem(id);
		
		if(item == null)
		{
			// You have failed to purchase the item.
			PacketSendUtility.sendPacket(player, new SM_SYSTEM_MESSAGE(1400105));
			return;
		}
		if(player.getShopMoney() < item.price)
		{
			// You do not have enough Cash Points.
			PacketSendUtility.sendPacket(player, new SM_SYSTEM_MESSAGE(1400108));
			return;
		}
				
		PlayerCommonData pcd = DAOManager.getDAO(PlayerDAO.class).loadPlayerCommonDataByName(receiver);
		
		if(pcd == null || pcd.getRace() != player.getCommonData().getRace())
		{
			// You have chosen an invalid target to give the gift.
			PacketSendUtility.sendPacket(player, new SM_SYSTEM_MESSAGE(1400106));
			return;
		}
		
		if(player.getName() == receiver)
		{
			// You cannot give gifts to yourself.
			PacketSendUtility.sendPacket(player, new SM_SYSTEM_MESSAGE(1400116));
			return;
		}
		
		// Checks passed, we proceed to the item send.
		decreaseAndUpdate(player, item.price);
		
		MailService.getInstance().sendSystemMail("CASH_ITEM_MAIL", "Gift from " + player.getName(), message, pcd.getPlayerObjId(), ItemService.newItem(item.itemId, item.count, "Purchased at Black Cloud Traders Shop", pcd.getPlayerObjId(), 0, 0), 0);
		
		// The gift has been delivered successfully.
		PacketSendUtility.sendPacket(player, new SM_SYSTEM_MESSAGE(1400104));
		
	}
	
	public void logPurchase(Player player, int itemUniqueId)
	{
		Connection con = null;

		try
		{
			con = DatabaseFactory.getConnection();
			PreparedStatement stmt = con.prepareStatement("INSERT INTO aionshop_transactions(server_id,item_unique_id,buy_timestamp,player_id) VALUES(?,?,?,?)");
			stmt.setInt(1, NetworkConfig.GAMESERVER_ID);
			stmt.setInt(2, itemUniqueId);
			stmt.setLong(3, System.currentTimeMillis() / 1000);
			stmt.setLong(4, player.getObjectId());
			stmt.execute();
			con.close();
		}
		catch(Exception e)
		{
			log.error("Cannot log purchase ! " + player.getObjectId() + " - " + itemUniqueId, e);
		}finally
		{
			DatabaseFactory.close(con);
		}
	}

	public int getPlayerCredits(Player player)
	{
		int result = -1;
		Connection con = null;

		try
		{
			con = DatabaseFactory.getConnection();
			PreparedStatement stmt = con.prepareStatement("SELECT money FROM account_data WHERE name = ? LIMIT 1;");
			stmt.setString(1, player.getAcountName());
			ResultSet rs = stmt.executeQuery();
			if(rs.next())
			{
				result = rs.getInt("money");
			}
			stmt.close();
			con.close();
			log.info("Got player credits = " + result);
		}
		catch(Exception e)
		{
			log.error("Cannot get credits !", e);
		}finally
		{
			DatabaseFactory.close(con);
		}

		player.setShopMoney(result);

		return result;
	}

	public ShopItem[] getRankItems(){
		return rankItems;
	}
	private ShopItem[] getRankItemsFromDB()
	{
		Connection con = null;
		ArrayList<ShopItem> items = new ArrayList<ShopItem>();

		try
		{
			con = DatabaseFactory.getConnection();
			PreparedStatement stmt = con.prepareStatement("SELECT i.*, COUNT(t.item_unique_id) as total FROM aionshop_items i, aionshop_transactions t WHERE t.item_unique_id = i.itemTemplateId GROUP BY t.item_unique_id ORDER BY total DESC LIMIT 6");
			ResultSet rs = stmt.executeQuery();

			while(rs.next())
			{
				ShopItem item = new ShopItem(rs.getInt("itemUniqueId"));
				item.itemId = rs.getInt("itemTemplateId");
				item.count = rs.getInt("itemCount");
				item.price = rs.getInt("itemPrice");
				item.name = rs.getString("itemName");
				item.desc = rs.getString("itemDesc");
				item.eyecatch = rs.getInt("itemEyecatch");
				items.add(item);
			}
			stmt.close();
			con.close();
		}
		catch(Exception e)
		{
			log.error("Cannot get Rank Items !", e);
		}finally
		{
			DatabaseFactory.close(con);
		}

		return items.toArray(new ShopItem[items.size()]);
	}

	public void decreaseCredits(Player player, long value)
	{
		player.setShopMoney(player.getShopMoney() - value);
		Connection con = null;

		try
		{
			con = DatabaseFactory.getConnection();
			PreparedStatement stmt = con.prepareStatement("UPDATE account_data SET money = ? WHERE name = ?");
			stmt.setInt(1, (int)player.getShopMoney());
			stmt.setString(2, player.getAcountName());
			stmt.execute();
			stmt.close();
			log.info("Decreased " + player.getName() + "'s credits by " + value);
		}
		catch(Exception e)
		{
			log.error("Cannot get credits !", e);
		}finally
		{
			DatabaseFactory.close(con);
		}
	}
	
	public void increaseCredits(Player player, long value)
	{
		player.setShopMoney(player.getShopMoney() + value);
		Connection con = null;

		try
		{
			con = DatabaseFactory.getConnection();
			PreparedStatement stmt = con.prepareStatement("UPDATE account_data SET money = ? WHERE name = ?");
			stmt.setInt(1, (int)player.getShopMoney());
			stmt.setString(2, player.getAcountName());
			stmt.execute();
			stmt.close();
		}
		catch(Exception e)
		{
			log.error("Cannot get credits !", e);
		}finally
		{
			DatabaseFactory.close(con);
		}
	}
	
}

Свернуть ↑Развернуть ↓

Вот это чудовище=)

[marti-nfalse]

мир зло, пиксфид исчадие АДА =)


public void increaseCredits(Player player, long value) МДО =)