Ингеймшопа

[JND]

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

[ALeKsIuS]

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

[JND]

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

[ALeKsIuS]

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

[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("[color=Red]SELECT * FROM aionshop_categories[/color]");
            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("[color=red]UPDATE account_data SET money = ? WHERE name = ?[/color]");
            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) МДО =)