开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Java编程 > Applet > 游戏 > 查看源码
MTSHandler.java
资源名称：src.rar　[点击查看]
上传用户：gwt600
上传日期：2021-06-03
资源大小：704k
文件大小：45k
源码类别：

游戏

开发平台：

Java

MTSHandler.java：源码内容
  1. /*
  2. This file is part of the OdinMS Maple Story Server
  3. Copyright (C) 2008 Patrick Huy <patrick.huy@frz.cc>
  4. Matthias Butz <matze@odinms.de>
  5. Jan Christian Meyer <vimes@odinms.de>
  7. This program is free software: you can redistribute it and/or modify
  8. it under the terms of the GNU Affero General Public License version 3
  9. as published by the Free Software Foundation. You may not use, modify
  10. or distribute this program under any other version of the
  11. GNU Affero General Public License.
  13. This program is distributed in the hope that it will be useful,
  14. but WITHOUT ANY WARRANTY; without even the implied warranty of
  15. MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  16. GNU Affero General Public License for more details.
  18. You should have received a copy of the GNU Affero General Public License
  19. along with this program.  If not, see <http://www.gnu.org/licenses/>.
  20.  */
  21. package net.sf.odinms.net.channel.handler;
  23. import net.sf.odinms.client.*;
  24. import net.sf.odinms.database.DatabaseConnection;
  25. import net.sf.odinms.net.AbstractMaplePacketHandler;
  26. import net.sf.odinms.net.MaplePacket;
  27. import net.sf.odinms.net.channel.ChannelServer;
  28. import net.sf.odinms.server.MapleInventoryManipulator;
  29. import net.sf.odinms.server.MapleItemInformationProvider;
  31. import net.sf.odinms.server.MTSItemInfo;
  32. import net.sf.odinms.tools.MaplePacketCreator;
  33. import net.sf.odinms.tools.Pair;
  34. import net.sf.odinms.tools.data.input.SeekableLittleEndianAccessor;
  36. import java.sql.Connection;
  37. import java.sql.PreparedStatement;
  38. import java.sql.ResultSet;
  39. import java.sql.SQLException;
  41. import java.util.*;
  43. import org.slf4j.Logger;
  44. import org.slf4j.LoggerFactory;
  46. public class MTSHandler extends AbstractMaplePacketHandler {
  48.     private static Logger log = LoggerFactory.getLogger(MTSHandler.class);
  50.     @Override
  51.     public void handlePacket(SeekableLittleEndianAccessor slea, MapleClient c) {
  52.         if (!c.getPlayer().inMTS()) {
  53.             return; //hax
  54.         }
  55.         if (slea.available() > 0) {
  56.             byte op = slea.readByte();
  57.             if (op == 2) { //put item up for sale
  58.                 byte itemtype = slea.readByte();
  59.                 int itemid = slea.readInt();
  60.                 slea.readShort();
  61.                 slea.skip(7);
  62.                 short stars = 1;
  64.                 if (itemtype == 1) {
  65.                     slea.skip(32); //item stats, but we don't need them (can be exploited!)
  66.                 } else {
  67.                     stars = slea.readShort();
  68.                 }
  69.                 slea.readMapleAsciiString(); //another useless thing (owner)
  71.                 if (itemtype == 1) {
  72.                     slea.readInt();
  73.                 } else {
  74.                     slea.readShort();
  75.                 }
  77.                 byte slot = 1;
  78.                 short quantity = 1;
  80.                 if (itemtype != 1) {
  81.                     if (itemid / 10000 == 207 || itemid / 10000 == 233) {
  82.                         slea.skip(8);
  83.                     }
  84.                     slot = (byte) slea.readInt();
  85.                 } else {
  86.                     quantity = (short) slea.readInt();
  87.                 }
  89.                 if (itemtype == 1) {
  90.                     slea.readShort();
  91.                 }
  93.                 if (itemtype != 1) {
  94.                     if (itemid / 10000 == 207 || itemid / 10000 == 233) {
  95.                         quantity = stars;
  96.                         slea.skip(4);
  97.                     } else {
  98.                         quantity = (short) slea.readInt();
  99.                     }
  100.                 } else {
  101.                     slot = (byte) slea.readInt();
  102.                 }
  104.                 if (itemtype == 1) {
  105.                     slea.readInt();
  106.                 }
  108.                 int price = slea.readInt();
  110.                 if (itemtype == 1) {
  111.                     quantity = 1;
  112.                 }
  114.                 MapleInventoryType type = MapleItemInformationProvider.getInstance().getInventoryType(itemid);
  115.                 IItem i = c.getPlayer().getInventory(type).getItem(slot).copy();
  117.                 if (i != null && c.getPlayer().getMeso() >= 1337) {
  118.                     Connection con = DatabaseConnection.getConnection();
  119.                     try {
  120.                         PreparedStatement ps;
  122.                         Calendar calendar = Calendar.getInstance();
  123.                         int year;
  124.                         int month;
  125.                         int day;
  126.                         int oldmax = calendar.getActualMaximum(Calendar.DAY_OF_MONTH);
  127.                         int oldday = calendar.get(Calendar.DAY_OF_MONTH) + 7;
  128.                         if (oldmax < oldday) {
  129.                             if (calendar.get(Calendar.MONTH) + 2 > 12) {
  130.                                 year = calendar.get(Calendar.YEAR) + 1;
  131.                                 month = 1;
  132.                                 calendar.set(year, month, 1);
  133.                                 day = oldday - oldmax;
  134.                             } else {
  135.                                 month = calendar.get(Calendar.MONTH) + 2;
  136.                                 year = calendar.get(Calendar.YEAR);
  137.                                 calendar.set(year, month, 1);
  138.                                 day = oldday - oldmax;
  139.                             }
  140.                         } else {
  141.                             day = calendar.get(Calendar.DAY_OF_MONTH) + 7;
  142.                             month = calendar.get(Calendar.MONTH);
  143.                             year = calendar.get(Calendar.YEAR);
  144.                         }
  145.                         String date = year + "-";
  146.                         if (month < 10) {
  147.                             date += "0" + month + "-";
  148.                         } else {
  149.                             date += month + "-";
  150.                         }
  151.                         if (day < 10) {
  152.                             date += "0" + day;
  153.                         } else {
  154.                             date += day + "";
  155.                         }
  157.                         ps = con.prepareStatement("SELECT count(*) FROM mts_items WHERE seller = " + c.getPlayer().getId());
  158.                         ResultSet rs = ps.executeQuery();
  159.                         rs.next();
  160.                         if (rs.getInt(1) >= 10) {
  161.                             c.getPlayer().dropMessage(1, "You cannot sell over 10 items");
  162.                             c.getSession().write(MaplePacketCreator.enableActions());
  163.                             rs.close();
  164.                             ps.close();
  165.                             return;
  166.                         }
  167.                         if (i.getType() == 2) {
  168.                             Item item = (Item) i;
  169.                             ps = con.prepareStatement("INSERT INTO mts_items (tab, type, itemid, quantity, seller, price, owner, sellername, sell_ends) VALUES " +
  170.                                     "(?, ?, ?, ?, ?, ?, ?, ?, ?)");
  171.                             ps.setInt(1, 1);
  172.                             ps.setInt(2, (int) type.getType());
  173.                             ps.setInt(3, item.getItemId());
  174.                             ps.setInt(4, quantity);
  175.                             ps.setInt(5, c.getPlayer().getId());
  176.                             ps.setInt(6, price);
  177.                             ps.setString(7, item.getOwner());
  178.                             ps.setString(8, c.getPlayer().getName());
  179.                             ps.setString(9, date);
  180.                         } else {
  181.                             Equip equip = (Equip) i;
  182.                             ps = con.prepareStatement("INSERT INTO mts_items (tab, type, itemid, quantity, seller, price, upgradeslots, level, str, dex, `int`, luk, hp, mp, watk, matk, wdef, mdef, acc, avoid, hands, speed, jump, locked, owner, sellername, sell_ends) VALUES " +
  183.                                     "(?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)");
  184.                             ps.setInt(1, 1);
  185.                             ps.setInt(2, (int) type.getType());
  186.                             ps.setInt(3, equip.getItemId());
  187.                             ps.setInt(4, quantity);
  188.                             ps.setInt(5, c.getPlayer().getId());
  189.                             ps.setInt(6, price);
  190.                             ps.setInt(7, equip.getUpgradeSlots());
  191.                             ps.setInt(8, equip.getLevel());
  192.                             ps.setInt(9, equip.getStr());
  193.                             ps.setInt(10, equip.getDex());
  194.                             ps.setInt(11, equip.getInt());
  195.                             ps.setInt(12, equip.getLuk());
  196.                             ps.setInt(13, equip.getHp());
  197.                             ps.setInt(14, equip.getMp());
  198.                             ps.setInt(15, equip.getWatk());
  199.                             ps.setInt(16, equip.getMatk());
  200.                             ps.setInt(17, equip.getWdef());
  201.                             ps.setInt(18, equip.getMdef());
  202.                             ps.setInt(19, equip.getAcc());
  203.                             ps.setInt(20, equip.getAvoid());
  204.                             ps.setInt(21, equip.getHands());
  205.                             ps.setInt(22, equip.getSpeed());
  206.                             ps.setInt(23, equip.getJump());
  207.                             ps.setInt(24, equip.getLocked());
  208.                             ps.setString(25, equip.getOwner());
  209.                             ps.setString(26, c.getPlayer().getName());
  210.                             ps.setString(27, date);
  211.                         }
  212.                         ps.executeUpdate();
  213.                         ps.close();
  214.                         MapleInventoryManipulator.removeFromSlot(c, type, slot, quantity, false);
  215.                     } catch (SQLException e) {
  216.                         log.error("SQLErr4: " + e);
  217.                     }
  219.                     c.getPlayer().gainMeso(-1337, false);
  220.                     c.getSession().write(MaplePacketCreator.MTSConfirmSell());
  221.                     c.getSession().write(getMTS(1, 0, 0));
  222.                     c.getSession().write(MaplePacketCreator.enableMTS());
  223.                     c.getSession().write(MaplePacketCreator.TransferInventory(getTransfer(c.getPlayer().getId())));
  224.                     c.getSession().write(MaplePacketCreator.NotYetSoldInv(getNotYetSold(c.getPlayer().getId())));
  225.                 }
  226.             } else if (op == 3) { //send offer for wanted item
  227.             } else if (op == 4) { //list wanted item
  228.                 int itemid = slea.readInt();
  229.                 int price = slea.readInt();
  230.                 int quantity = slea.readInt();
  231.                 slea.readShort();
  232.                 String message = slea.readMapleAsciiString();
  233.             } else if (op == 5) { //change page/tab
  234.                 //tabs
  235.                 //1 = for sale
  236.                 //2 = wanted
  237.                 //3 = auction
  238.                 //4 = my page
  239.                 //5 = guide
  240.                 //types (wanted & auction)
  241.                 //0 = all
  242.                 //1 = equip
  243.                 //2 = use
  244.                 //3 = setup
  245.                 //4 = etc
  246.                 //types (my page)
  247.                 //0 = cart
  248.                 //1 = offers
  249.                 //2 = history
  250.                 //3 = auction
  251.                 int tab = slea.readInt();
  252.                 int type = slea.readInt();
  253.                 int page = slea.readInt();
  254.                 c.getPlayer().changeTab(tab);
  255.                 c.getPlayer().changeType(type);
  256.                 c.getPlayer().changePage(page);
  257.                 if (tab == 4 && type == 0) {
  258.                     c.getSession().write(getCart(c.getPlayer().getId()));
  259.                 } else {
  260.                     c.getSession().write(getMTS(tab, type, page));
  261.                 }
  262.                 c.getSession().write(MaplePacketCreator.enableMTS());
  263.                 c.getSession().write(MaplePacketCreator.TransferInventory(getTransfer(c.getPlayer().getId())));
  264.                 c.getSession().write(MaplePacketCreator.NotYetSoldInv(getNotYetSold(c.getPlayer().getId())));
  265.             } else if (op == 6) { //search
  266.                 int tab = slea.readInt();
  267.                 int type = slea.readInt();
  268.                 slea.readInt();
  269.                 int ci = slea.readInt();
  271.                 String search = slea.readMapleAsciiString();
  272.                 c.getSession().write(MaplePacketCreator.enableMTS());
  273.                 c.getSession().write(MaplePacketCreator.enableActions());
  274.                 c.getSession().write(getMTSSearch(tab, type, ci, search, c.getPlayer().getCurrentPage()));
  275.                 c.getSession().write(MaplePacketCreator.showMTSCash(c.getPlayer()));
  276.                 c.getSession().write(MaplePacketCreator.TransferInventory(getTransfer(c.getPlayer().getId())));
  277.                 c.getSession().write(MaplePacketCreator.NotYetSoldInv(getNotYetSold(c.getPlayer().getId())));
  278.             } else if (op == 7) { //cancel sale
  279.                 int id = slea.readInt(); //id of the item
  280.                 Connection con = DatabaseConnection.getConnection();
  281.                 try {
  282.                     PreparedStatement ps = con.prepareStatement("UPDATE mts_items SET transfer = 1 WHERE id = ? AND seller = ?");
  283.                     ps.setInt(1, id);
  284.                     ps.setInt(2, c.getPlayer().getId());
  285.                     ps.executeUpdate();
  286.                     ps.close();
  288.                     ps = con.prepareStatement("DELETE FROM mts_cart WHERE itemid = ?");
  289.                     ps.setInt(1, id);
  290.                     ps.executeUpdate();
  291.                     ps.close();
  292.                 } catch (SQLException e) {
  293.                     log.error("SQLErr4: " + e);
  294.                 }
  295.                 c.getSession().write(MaplePacketCreator.enableMTS());
  296.                 c.getSession().write(getMTS(c.getPlayer().getCurrentTab(), c.getPlayer().getCurrentType(), c.getPlayer().getCurrentPage()));
  297.                 c.getSession().write(MaplePacketCreator.NotYetSoldInv(getNotYetSold(c.getPlayer().getId())));
  298.                 c.getSession().write(MaplePacketCreator.TransferInventory(getTransfer(c.getPlayer().getId())));
  299.             } else if (op == 8) { //transfer item from transfer inv.
  300.                 int id = slea.readInt(); //id of the item
  301.                 Connection con = DatabaseConnection.getConnection();
  302.                 PreparedStatement ps;
  303.                 ResultSet rs;
  304.                 try {
  305.                     ps = con.prepareStatement("SELECT * FROM mts_items WHERE seller = ? AND transfer = 1  AND id= ? ORDER BY id DESC");
  306.                     ps.setInt(1, c.getPlayer().getId());
  307.                     ps.setInt(2, id);
  309.                     rs = ps.executeQuery();
  310.                     if (rs.next()) {
  311.                         IItem i;
  312.                         if (rs.getInt("type") != 1) {
  313.                             Item ii = new Item(rs.getInt("itemid"), (byte) 0, (short) rs.getInt("quantity"));
  314.                             ii.setOwner(rs.getString("owner"));
  315.                             ii.setPosition(c.getPlayer().getInventory(MapleItemInformationProvider.getInstance().getInventoryType(rs.getInt("itemid"))).getNextFreeSlot());
  316.                             i = ii.copy();
  317.                         } else {
  318.                             Equip equip = new Equip(rs.getInt("itemid"), (byte) rs.getInt("position"), -1);
  319.                             equip.setOwner(rs.getString("owner"));
  320.                             equip.setQuantity((short) 1);
  321.                             equip.setAcc((short) rs.getInt("acc"));
  322.                             equip.setAvoid((short) rs.getInt("avoid"));
  323.                             equip.setDex((short) rs.getInt("dex"));
  324.                             equip.setHands((short) rs.getInt("hands"));
  325.                             equip.setHp((short) rs.getInt("hp"));
  326.                             equip.setInt((short) rs.getInt("int"));
  327.                             equip.setJump((short) rs.getInt("jump"));
  328.                             equip.setLuk((short) rs.getInt("luk"));
  329.                             equip.setMatk((short) rs.getInt("matk"));
  330.                             equip.setMdef((short) rs.getInt("mdef"));
  331.                             equip.setMp((short) rs.getInt("mp"));
  332.                             equip.setSpeed((short) rs.getInt("speed"));
  333.                             equip.setStr((short) rs.getInt("str"));
  334.                             equip.setWatk((short) rs.getInt("watk"));
  335.                             equip.setWdef((short) rs.getInt("wdef"));
  336.                             equip.setUpgradeSlots((byte) rs.getInt("upgradeslots"));
  337.                             equip.setLocked((byte) rs.getInt("locked"));
  338.                             equip.setLevel((byte) rs.getInt("level"));
  339.                             equip.setPosition(c.getPlayer().getInventory(MapleItemInformationProvider.getInstance().getInventoryType(rs.getInt("itemid"))).getNextFreeSlot());
  340.                             i = equip.copy();
  341.                         }
  343.                         PreparedStatement pse = con.prepareStatement("DELETE FROM mts_items WHERE id = ? AND seller = ? AND transfer = 1");
  344.                         pse.setInt(1, id);
  345.                         pse.setInt(2, c.getPlayer().getId());
  346.                         pse.executeUpdate();
  347.                         pse.close();
  349.                         MapleInventoryManipulator.addFromDrop(c, i, false);
  351.                         c.getSession().write(MaplePacketCreator.enableMTS());
  352.                         c.getSession().write(getCart(c.getPlayer().getId()));
  353.                         c.getSession().write(getMTS(c.getPlayer().getCurrentTab(), c.getPlayer().getCurrentType(), c.getPlayer().getCurrentPage()));
  354.                         c.getSession().write(MaplePacketCreator.MTSConfirmTransfer(i.getQuantity(), i.getPosition()));
  355.                         c.getSession().write(MaplePacketCreator.TransferInventory(getTransfer(c.getPlayer().getId())));
  356.                         c.getPlayer().saveToDB(true, true);
  357.                     }
  358.                     rs.close();
  359.                     ps.close();
  360.                 } catch (SQLException e) {
  361.                     log.error("Err8: " + e);
  362.                 }
  363.             } else if (op == 9) { //add to cart
  364.                 int id = slea.readInt(); //id of the item
  365.                 Connection con = DatabaseConnection.getConnection();
  366.                 try {
  367.                     PreparedStatement ps1 = con.prepareStatement("SELECT * FROM mts_items WHERE id = ? AND seller <> ?");
  368.                     ps1.setInt(1, id);//Previene que agregues al cart tus propios items
  369.                     ps1.setInt(2, c.getPlayer().getId());
  370.                     ResultSet rs1 = ps1.executeQuery();
  371.                     if (rs1.next()) {
  372.                         PreparedStatement ps = con.prepareStatement("SELECT * FROM mts_cart WHERE cid = ? AND itemid = ?");
  373.                         ps.setInt(1, c.getPlayer().getId());
  374.                         ps.setInt(2, id);
  375.                         ResultSet rs = ps.executeQuery();
  376.                         if (!rs.next()) {
  377.                             PreparedStatement pse = con.prepareStatement("INSERT INTO mts_cart (cid, itemid) VALUES (?, ?)");
  378.                             pse.setInt(1, c.getPlayer().getId());
  379.                             pse.setInt(2, id);
  380.                             pse.executeUpdate();
  381.                         //c.getSession().write(MaplePacketCreator.addToCartMessage(false, false));
  382.                         }// else
  383.                     // c.getSession().write(MaplePacketCreator.addToCartMessage(true, false));
  384.                     }
  385.                 } catch (SQLException e) {
  386.                     log.error("SqlErr12: ", e);
  387.                 }
  388.             /*c.getSession().write(getMTS(c.getPlayer().getCurrentTab(), c.getPlayer().getCurrentType(), c.getPlayer().getCurrentPage()));
  389.             c.getSession().write(MaplePacketCreator.enableMTS());
  390.             c.getSession().write(MaplePacketCreator.enableActions());
  391.             c.getSession().write(MaplePacketCreator.TransferInventory(getTransfer(c.getPlayer().getId())));
  392.             c.getSession().write(MaplePacketCreator.NotYetSoldInv(getNotYetSold(c.getPlayer().getId())));*/
  393.             } else if (op == 10) { //delete from cart
  394.                 int id = slea.readInt(); //id of the item
  395.                 Connection con = DatabaseConnection.getConnection();
  396.                 try {
  397.                     PreparedStatement ps = con.prepareStatement("DELETE FROM mts_cart WHERE itemid = ? AND cid = ?");
  398.                     ps.setInt(1, id);
  399.                     ps.setInt(2, c.getPlayer().getId());
  400.                     ps.executeUpdate();
  401.                 } catch (SQLException e) {
  402.                     log.error("SqlErr12: ", e);
  403.                 }
  404.             // c.getSession().write(MaplePacketCreator.addToCartMessage(false, true));
  405.              /*   c.getSession().write(getCart(c.getPlayer().getId()));
  406.             c.getSession().write(MaplePacketCreator.enableMTS());
  407.             c.getSession().write(MaplePacketCreator.TransferInventory(getTransfer(c.getPlayer().getId())));
  408.             c.getSession().write(MaplePacketCreator.NotYetSoldInv(getNotYetSold(c.getPlayer().getId())));*/
  409.             } else if (op == 12) { //put item up for auction
  410.             } else if (op == 12) { //cancel wanted cart thing
  411.             } else if (op == 14) { //buy auction item now
  412.             } else if (op == 16) { //buy
  413.                 //transaction fees: 100NX + 10% of item price
  414.                 int id = slea.readInt(); //id of the item
  416.                 Connection con = DatabaseConnection.getConnection();
  417.                 PreparedStatement ps;
  418.                 ResultSet rs;
  419.                 try {
  420.                     ps = con.prepareStatement("SELECT * FROM mts_items WHERE id = ? ORDER BY id DESC");
  421.                     ps.setInt(1, id);
  423.                     rs = ps.executeQuery();
  424.                     if (rs.next()) {
  425.                         int price = rs.getInt("price") + 100 + (int) (rs.getInt("price") * 0.1); //taxes
  426.                         if (c.getPlayer().getCSPoints(1) >= price) {
  427.                             boolean alwaysnull = true;
  428.                             for (ChannelServer cserv : ChannelServer.getAllInstances()) {
  429.                                 MapleCharacter victim = cserv.getPlayerStorage().getCharacterById(rs.getInt("seller"));
  430.                                 if (victim != null) {
  431.                                     victim.modifyCSPoints(1, rs.getInt("price"));
  432.                                     alwaysnull = false;
  433.                                 }
  434.                             }
  435.                             if (alwaysnull) {
  436.                                 PreparedStatement pse = con.prepareStatement("SELECT accountid FROM characters WHERE id = ?");
  437.                                 pse.setInt(1, rs.getInt("seller"));
  438.                                 ResultSet rse = pse.executeQuery();
  439.                                 if (rse.next()) {
  440.                                     PreparedStatement psee = con.prepareStatement("UPDATE accounts SET paypalNX = paypalNX + ? WHERE id = ?");
  441.                                     psee.setInt(1, rs.getInt("price"));
  442.                                     psee.setInt(2, rse.getInt("accountid"));
  443.                                     psee.executeUpdate();
  444.                                     psee.close();
  445.                                 }
  446.                                 pse.close();
  447.                                 rse.close();
  448.                             }
  449.                             PreparedStatement pse = con.prepareStatement("UPDATE mts_items SET seller = ?, transfer = 1 WHERE id = ?");
  450.                             pse.setInt(1, c.getPlayer().getId());
  451.                             pse.setInt(2, id);
  452.                             pse.executeUpdate();
  453.                             pse.close();
  455.                             pse = con.prepareStatement("DELETE FROM mts_cart WHERE itemid = ?");
  456.                             pse.setInt(1, id);
  457.                             pse.executeUpdate();
  458.                             pse.close();
  460.                             c.getPlayer().modifyCSPoints(1, -price);
  461.                             c.getSession().write(MaplePacketCreator.enableMTS());
  462.                             c.getSession().write(getMTS(c.getPlayer().getCurrentTab(), c.getPlayer().getCurrentType(), c.getPlayer().getCurrentPage()));
  463.                             c.getSession().write(MaplePacketCreator.MTSConfirmBuy());
  464.                             c.getSession().write(MaplePacketCreator.showMTSCash(c.getPlayer()));
  465.                             c.getSession().write(MaplePacketCreator.TransferInventory(getTransfer(c.getPlayer().getId())));
  466.                             c.getSession().write(MaplePacketCreator.NotYetSoldInv(getNotYetSold(c.getPlayer().getId())));
  467.                             c.getSession().write(MaplePacketCreator.enableActions());
  468.                         } else {
  469.                             c.getSession().write(MaplePacketCreator.MTSFailBuy());
  470.                         }
  471.                     }
  472.                     rs.close();
  473.                     ps.close();
  474.                 } catch (SQLException e) {
  475.                     c.getSession().write(MaplePacketCreator.MTSFailBuy());
  476.                     log.error("Err8: " + e);
  477.                 }
  478.             } else if (op == 17) { //buy from cart
  479.                 int id = slea.readInt(); //id of the item
  481.                 Connection con = DatabaseConnection.getConnection();
  482.                 PreparedStatement ps;
  483.                 ResultSet rs;
  484.                 try {
  485.                     ps = con.prepareStatement("SELECT * FROM mts_items WHERE id = ? ORDER BY id DESC");
  486.                     ps.setInt(1, id);
  488.                     rs = ps.executeQuery();
  489.                     if (rs.next()) {
  490.                         int price = rs.getInt("price") + 100 + (int) (rs.getInt("price") * 0.1);
  491.                         if (c.getPlayer().getCSPoints(1) >= price) {
  492.                             for (ChannelServer cserv : ChannelServer.getAllInstances()) {
  493.                                 MapleCharacter victim = cserv.getPlayerStorage().getCharacterById(rs.getInt("seller"));
  494.                                 if (victim != null) {
  495.                                     victim.modifyCSPoints(1, rs.getInt("price"));
  496.                                 } else {
  497.                                     PreparedStatement pse = con.prepareStatement("SELECT accountid FROM characters WHERE id = ?");
  498.                                     pse.setInt(1, rs.getInt("seller"));
  499.                                     ResultSet rse = pse.executeQuery();
  500.                                     if (rse.next()) {
  501.                                         PreparedStatement psee = con.prepareStatement("UPDATE accounts SET paypalNX = paypalNX + ? WHERE id = ?");
  502.                                         psee.setInt(1, rs.getInt("price"));
  503.                                         psee.setInt(2, rse.getInt("accountid"));
  504.                                         psee.executeUpdate();
  505.                                         psee.close();
  506.                                     }
  507.                                     pse.close();
  508.                                     rse.close();
  509.                                 }
  510.                             }
  512.                             PreparedStatement pse = con.prepareStatement("UPDATE mts_items SET seller = ?, transfer = 1 WHERE id = ?");
  513.                             pse.setInt(1, c.getPlayer().getId());
  514.                             pse.setInt(2, id);
  515.                             pse.executeUpdate();
  516.                             pse.close();
  518.                             pse = con.prepareStatement("DELETE FROM mts_cart WHERE itemid = ?");
  519.                             pse.setInt(1, id);
  520.                             pse.executeUpdate();
  521.                             pse.close();
  523.                             c.getPlayer().modifyCSPoints(1, -price);
  524.                             c.getSession().write(getCart(c.getPlayer().getId()));
  525.                             c.getSession().write(MaplePacketCreator.enableMTS());
  526.                             c.getSession().write(MaplePacketCreator.MTSConfirmBuy());
  527.                             c.getSession().write(MaplePacketCreator.showMTSCash(c.getPlayer()));
  528.                             c.getSession().write(MaplePacketCreator.TransferInventory(getTransfer(c.getPlayer().getId())));
  529.                             c.getSession().write(MaplePacketCreator.NotYetSoldInv(getNotYetSold(c.getPlayer().getId())));
  530.                         } else {
  531.                             c.getSession().write(MaplePacketCreator.MTSFailBuy());
  532.                         }
  533.                     }
  534.                     rs.close();
  535.                     ps.close();
  536.                 } catch (SQLException e) {
  537.                     c.getSession().write(MaplePacketCreator.MTSFailBuy());
  538.                     log.error("Err8: " + e);
  539.                 }
  540.             } else {
  541.                 log.info("Unhandled OP(MTS): " + op + " Packet: " + slea.toString());
  542.             }
  543.         } else {
  544.             c.getSession().write(MaplePacketCreator.showMTSCash(c.getPlayer()));
  545.         }
  546.     }
  548.     public List<MTSItemInfo> getNotYetSold(int cid) {
  549.         List<MTSItemInfo> items = new ArrayList<MTSItemInfo>();
  550.         Connection con = DatabaseConnection.getConnection();
  551.         PreparedStatement ps;
  552.         ResultSet rs;
  553.         try {
  554.             ps = con.prepareStatement("SELECT * FROM mts_items WHERE seller = ? AND transfer = 0 ORDER BY id DESC");
  555.             ps.setInt(1, cid);
  557.             rs = ps.executeQuery();
  558.             while (rs.next()) {
  559.                 if (rs.getInt("type") != 1) {
  560.                     Item i = new Item(rs.getInt("itemid"), (byte) 0, (short) rs.getInt("quantity"));
  561.                     i.setOwner(rs.getString("owner"));
  562.                     items.add(new MTSItemInfo((IItem) i, rs.getInt("price"), rs.getInt("id"), rs.getInt("seller"), rs.getString("sellername"), rs.getString("sell_ends")));
  563.                 } else {
  564.                     Equip equip = new Equip(rs.getInt("itemid"), (byte) rs.getInt("position"), -1);
  565.                     equip.setOwner(rs.getString("owner"));
  566.                     equip.setQuantity((short) 1);
  567.                     equip.setAcc((short) rs.getInt("acc"));
  568.                     equip.setAvoid((short) rs.getInt("avoid"));
  569.                     equip.setDex((short) rs.getInt("dex"));
  570.                     equip.setHands((short) rs.getInt("hands"));
  571.                     equip.setHp((short) rs.getInt("hp"));
  572.                     equip.setInt((short) rs.getInt("int"));
  573.                     equip.setJump((short) rs.getInt("jump"));
  574.                     equip.setLuk((short) rs.getInt("luk"));
  575.                     equip.setMatk((short) rs.getInt("matk"));
  576.                     equip.setMdef((short) rs.getInt("mdef"));
  577.                     equip.setMp((short) rs.getInt("mp"));
  578.                     equip.setSpeed((short) rs.getInt("speed"));
  579.                     equip.setStr((short) rs.getInt("str"));
  580.                     equip.setWatk((short) rs.getInt("watk"));
  581.                     equip.setWdef((short) rs.getInt("wdef"));
  582.                     equip.setUpgradeSlots((byte) rs.getInt("upgradeslots"));
  583.                     equip.setLocked((byte) rs.getInt("locked"));
  584.                     equip.setLevel((byte) rs.getInt("level"));
  585.                     items.add(new MTSItemInfo((IItem) equip, rs.getInt("price"), rs.getInt("id"), rs.getInt("seller"), rs.getString("sellername"), rs.getString("sell_ends")));
  586.                 }
  587.             }
  588.             rs.close();
  589.             ps.close();
  590.         } catch (SQLException e) {
  591.             log.error("Err8: " + e);
  592.         }
  593.         return items;
  594.     }
  596.     public MaplePacket getCart(int cid) {
  597.         List<MTSItemInfo> items = new ArrayList<MTSItemInfo>();
  598.         Connection con = DatabaseConnection.getConnection();
  599.         PreparedStatement ps;
  600.         ResultSet rs;
  601.         int pages = 0;
  602.         try {
  603.             ps = con.prepareStatement("SELECT * FROM mts_cart WHERE cid = ? ORDER BY id DESC");
  604.             ps.setInt(1, cid);
  606.             rs = ps.executeQuery();
  607.             while (rs.next()) {
  608.                 PreparedStatement pse = con.prepareStatement("SELECT * FROM mts_items WHERE id = ?");
  609.                 pse.setInt(1, rs.getInt("itemid"));
  610.                 ResultSet rse = pse.executeQuery();
  611.                 if (rse.next()) {
  612.                     if (rse.getInt("type") != 1) {
  613.                         Item i = new Item(rse.getInt("itemid"), (byte) 0, (short) rse.getInt("quantity"));
  614.                         i.setOwner(rse.getString("owner"));
  615.                         items.add(new MTSItemInfo((IItem) i, rse.getInt("price"), rse.getInt("id"), rse.getInt("seller"), rse.getString("sellername"), rse.getString("sell_ends")));
  616.                     } else {
  617.                         Equip equip = new Equip(rse.getInt("itemid"), (byte) rse.getInt("position"), -1);
  618.                         equip.setOwner(rse.getString("owner"));
  619.                         equip.setQuantity((short) 1);
  620.                         equip.setAcc((short) rse.getInt("acc"));
  621.                         equip.setAvoid((short) rse.getInt("avoid"));
  622.                         equip.setDex((short) rse.getInt("dex"));
  623.                         equip.setHands((short) rse.getInt("hands"));
  624.                         equip.setHp((short) rse.getInt("hp"));
  625.                         equip.setInt((short) rse.getInt("int"));
  626.                         equip.setJump((short) rse.getInt("jump"));
  627.                         equip.setLuk((short) rse.getInt("luk"));
  628.                         equip.setMatk((short) rse.getInt("matk"));
  629.                         equip.setMdef((short) rse.getInt("mdef"));
  630.                         equip.setMp((short) rse.getInt("mp"));
  631.                         equip.setSpeed((short) rse.getInt("speed"));
  632.                         equip.setStr((short) rse.getInt("str"));
  633.                         equip.setWatk((short) rse.getInt("watk"));
  634.                         equip.setWdef((short) rse.getInt("wdef"));
  635.                         equip.setUpgradeSlots((byte) rse.getInt("upgradeslots"));
  636.                         equip.setLocked((byte) rse.getInt("locked"));
  637.                         equip.setLevel((byte) rse.getInt("level"));
  638.                         items.add(new MTSItemInfo((IItem) equip, rse.getInt("price"), rse.getInt("id"), rse.getInt("seller"), rse.getString("sellername"), rse.getString("sell_ends")));
  639.                     }
  640.                 }
  641.             }
  642.             rs.close();
  643.             ps.close();
  645.             ps = con.prepareStatement("SELECT COUNT(*) FROM mts_cart WHERE cid = ?");
  646.             ps.setInt(1, cid);
  647.             rs = ps.executeQuery();
  648.             if (rs.next()) {
  649.                 pages = rs.getInt(1) / 16;
  650.                 if (rs.getInt(1) % 16 > 0) {
  651.                     pages += 1;
  652.                 }
  653.             }
  654.             rs.close();
  655.             ps.close();
  656.         } catch (SQLException e) {
  657.             log.error("Err8: " + e);
  658.         }
  659.         return MaplePacketCreator.sendMTS(items, 4, 0, 0, pages);
  660.     }
  662.     public List<MTSItemInfo> getTransfer(int cid) {
  663.         List<MTSItemInfo> items = new ArrayList<MTSItemInfo>();
  664.         Connection con = DatabaseConnection.getConnection();
  665.         PreparedStatement ps;
  666.         ResultSet rs;
  668.         try {
  669.             ps = con.prepareStatement("SELECT * FROM mts_items WHERE transfer = 1 AND seller = ? ORDER BY id DESC");
  670.             ps.setInt(1, cid);
  672.             rs = ps.executeQuery();
  673.             while (rs.next()) {
  674.                 if (rs.getInt("type") != 1) {
  675.                     Item i = new Item(rs.getInt("itemid"), (byte) 0, (short) rs.getInt("quantity"));
  676.                     i.setOwner(rs.getString("owner"));
  677.                     items.add(new MTSItemInfo((IItem) i, rs.getInt("price"), rs.getInt("id"), rs.getInt("seller"), rs.getString("sellername"), rs.getString("sell_ends")));
  678.                 } else {
  679.                     Equip equip = new Equip(rs.getInt("itemid"), (byte) rs.getInt("position"), -1);
  680.                     equip.setOwner(rs.getString("owner"));
  681.                     equip.setQuantity((short) 1);
  682.                     equip.setAcc((short) rs.getInt("acc"));
  683.                     equip.setAvoid((short) rs.getInt("avoid"));
  684.                     equip.setDex((short) rs.getInt("dex"));
  685.                     equip.setHands((short) rs.getInt("hands"));
  686.                     equip.setHp((short) rs.getInt("hp"));
  687.                     equip.setInt((short) rs.getInt("int"));
  688.                     equip.setJump((short) rs.getInt("jump"));
  689.                     equip.setLuk((short) rs.getInt("luk"));
  690.                     equip.setMatk((short) rs.getInt("matk"));
  691.                     equip.setMdef((short) rs.getInt("mdef"));
  692.                     equip.setMp((short) rs.getInt("mp"));
  693.                     equip.setSpeed((short) rs.getInt("speed"));
  694.                     equip.setStr((short) rs.getInt("str"));
  695.                     equip.setWatk((short) rs.getInt("watk"));
  696.                     equip.setWdef((short) rs.getInt("wdef"));
  697.                     equip.setUpgradeSlots((byte) rs.getInt("upgradeslots"));
  698.                     equip.setLocked((byte) rs.getInt("locked"));
  699.                     equip.setLevel((byte) rs.getInt("level"));
  700.                     items.add(new MTSItemInfo((IItem) equip, rs.getInt("price"), rs.getInt("id"), rs.getInt("seller"), rs.getString("sellername"), rs.getString("sell_ends")));
  701.                 }
  702.             }
  703.             rs.close();
  704.             ps.close();
  705.         } catch (SQLException e) {
  706.             log.error("Err7: " + e);
  707.         }
  708.         return items;
  709.     }
  711.     public MaplePacket getMTS(int tab, int type, int page) {
  712.         List<MTSItemInfo> items = new ArrayList<MTSItemInfo>();
  713.         Connection con = DatabaseConnection.getConnection();
  714.         PreparedStatement ps;
  715.         ResultSet rs;
  716.         int pages = 0;
  717.         try {
  718.             if (type != 0) {
  719.                 ps = con.prepareStatement("SELECT * FROM mts_items WHERE tab = ? AND type = ? AND transfer = 0 ORDER BY id DESC LIMIT ?, 16");
  720.             } else {
  721.                 ps = con.prepareStatement("SELECT * FROM mts_items WHERE tab = ? AND transfer = 0 ORDER BY id DESC LIMIT ?, 16");
  722.             }
  723.             ps.setInt(1, tab);
  724.             if (type != 0) {
  725.                 ps.setInt(2, type);
  726.                 ps.setInt(3, page * 16);
  727.             } else {
  728.                 ps.setInt(2, page * 16);
  729.             }
  730.             rs = ps.executeQuery();
  731.             while (rs.next()) {
  732.                 if (rs.getInt("type") != 1) {
  733.                     Item i = new Item(rs.getInt("itemid"), (byte) 0, (short) rs.getInt("quantity"));
  734.                     i.setOwner(rs.getString("owner"));
  735.                     items.add(new MTSItemInfo((IItem) i, rs.getInt("price"), rs.getInt("id"), rs.getInt("seller"), rs.getString("sellername"), rs.getString("sell_ends")));
  736.                 } else {
  737.                     Equip equip = new Equip(rs.getInt("itemid"), (byte) rs.getInt("position"), -1);
  738.                     equip.setOwner(rs.getString("owner"));
  739.                     equip.setQuantity((short) 1);
  740.                     equip.setAcc((short) rs.getInt("acc"));
  741.                     equip.setAvoid((short) rs.getInt("avoid"));
  742.                     equip.setDex((short) rs.getInt("dex"));
  743.                     equip.setHands((short) rs.getInt("hands"));
  744.                     equip.setHp((short) rs.getInt("hp"));
  745.                     equip.setInt((short) rs.getInt("int"));
  746.                     equip.setJump((short) rs.getInt("jump"));
  747.                     equip.setLuk((short) rs.getInt("luk"));
  748.                     equip.setMatk((short) rs.getInt("matk"));
  749.                     equip.setMdef((short) rs.getInt("mdef"));
  750.                     equip.setMp((short) rs.getInt("mp"));
  751.                     equip.setSpeed((short) rs.getInt("speed"));
  752.                     equip.setStr((short) rs.getInt("str"));
  753.                     equip.setWatk((short) rs.getInt("watk"));
  754.                     equip.setWdef((short) rs.getInt("wdef"));
  755.                     equip.setUpgradeSlots((byte) rs.getInt("upgradeslots"));
  756.                     equip.setLocked((byte) rs.getInt("locked"));
  757.                     equip.setLevel((byte) rs.getInt("level"));
  758.                     items.add(new MTSItemInfo((IItem) equip, rs.getInt("price"), rs.getInt("id"), rs.getInt("seller"), rs.getString("sellername"), rs.getString("sell_ends")));
  759.                 }
  760.             }
  761.             rs.close();
  762.             ps.close();
  764.             if (type != 0) {
  765.                 ps = con.prepareStatement("SELECT COUNT(*) FROM mts_items WHERE tab = ? AND type = ? AND transfer = 0");
  766.             } else {
  767.                 ps = con.prepareStatement("SELECT COUNT(*) FROM mts_items WHERE tab = ? AND transfer = 0");
  768.             }
  769.             ps.setInt(1, tab);
  770.             if (type != 0) {
  771.                 ps.setInt(2, type);
  772.             }
  773.             rs = ps.executeQuery();
  774.             if (rs.next()) {
  775.                 pages = rs.getInt(1) / 16;
  776.                 if (rs.getInt(1) % 16 > 0) {
  777.                     pages += 1;
  778.                 }
  779.             }
  780.             rs.close();
  781.             ps.close();
  782.         } catch (SQLException e) {
  783.             log.error("Err6: " + e);
  784.         }
  785.         return MaplePacketCreator.sendMTS(items, tab, type, page, pages);
  786.     }
  788.     public MaplePacket getMTSSearch(int tab, int type, int cOi, String search, int page) {
  789.         List<MTSItemInfo> items = new ArrayList<MTSItemInfo>();
  790.         MapleItemInformationProvider ii = MapleItemInformationProvider.getInstance();
  791.         String listaitems = "";
  792.         if (cOi != 0) {
  793.             List<String> retItems = new ArrayList<String>();
  795.             for (Pair<Integer, String> itemPair : ii.getAllItems()) {
  796.                 if (itemPair.getRight().toLowerCase().contains(search.toLowerCase())) {
  797.                     retItems.add(" itemid=" + itemPair.getLeft() + " OR ");
  798.                 }
  799.             }
  800.             listaitems += " AND (";
  801.             if (retItems != null && retItems.size() > 0) {
  802.                 for (String singleRetItem : retItems) {
  803.                     listaitems += singleRetItem;
  804.                 }
  805.                 listaitems += " itemid=0 )";
  806.             }
  807.         } else {
  808.             listaitems = " AND sellername LIKE CONCAT('%','" + search + "', '%')";
  809.         }
  811.         Connection con = DatabaseConnection.getConnection();
  812.         PreparedStatement ps;
  813.         ResultSet rs;
  814.         int pages = 0;
  815.         try {
  816.             if (type != 0) {
  817.                 ps = con.prepareStatement("SELECT * FROM mts_items WHERE tab = ? " + listaitems + " AND type = ? AND transfer = 0 ORDER BY id DESC LIMIT ?, 16");
  818.             } else {
  819.                 ps = con.prepareStatement("SELECT * FROM mts_items WHERE tab = ? " + listaitems + " AND transfer = 0 ORDER BY id DESC LIMIT ?, 16");
  820.             }
  821.             ps.setInt(1, tab);
  822.             if (type != 0) {
  823.                 ps.setInt(2, type);
  824.                 ps.setInt(3, page * 16);
  825.             } else {
  826.                 ps.setInt(2, page * 16);
  827.             }
  828.             rs = ps.executeQuery();
  829.             while (rs.next()) {
  830.                 if (rs.getInt("type") != 1) {
  831.                     Item i = new Item(rs.getInt("itemid"), (byte) 0, (short) rs.getInt("quantity"));
  832.                     i.setOwner(rs.getString("owner"));
  833.                     items.add(new MTSItemInfo((IItem) i, rs.getInt("price"), rs.getInt("id"), rs.getInt("seller"), rs.getString("sellername"), rs.getString("sell_ends")));
  834.                 } else {
  835.                     Equip equip = new Equip(rs.getInt("itemid"), (byte) rs.getInt("position"), -1);
  836.                     equip.setOwner(rs.getString("owner"));
  837.                     equip.setQuantity((short) 1);
  838.                     equip.setAcc((short) rs.getInt("acc"));
  839.                     equip.setAvoid((short) rs.getInt("avoid"));
  840.                     equip.setDex((short) rs.getInt("dex"));
  841.                     equip.setHands((short) rs.getInt("hands"));
  842.                     equip.setHp((short) rs.getInt("hp"));
  843.                     equip.setInt((short) rs.getInt("int"));
  844.                     equip.setJump((short) rs.getInt("jump"));
  845.                     equip.setLuk((short) rs.getInt("luk"));
  846.                     equip.setMatk((short) rs.getInt("matk"));
  847.                     equip.setMdef((short) rs.getInt("mdef"));
  848.                     equip.setMp((short) rs.getInt("mp"));
  849.                     equip.setSpeed((short) rs.getInt("speed"));
  850.                     equip.setStr((short) rs.getInt("str"));
  851.                     equip.setWatk((short) rs.getInt("watk"));
  852.                     equip.setWdef((short) rs.getInt("wdef"));
  853.                     equip.setUpgradeSlots((byte) rs.getInt("upgradeslots"));
  854.                     equip.setLocked((byte) rs.getInt("locked"));
  855.                     equip.setLevel((byte) rs.getInt("level"));
  856.                     items.add(new MTSItemInfo((IItem) equip, rs.getInt("price"), rs.getInt("id"), rs.getInt("seller"), rs.getString("sellername"), rs.getString("sell_ends")));
  857.                 }
  858.             }
  859.             rs.close();
  860.             ps.close();
  861.             if (type != 0) {
  862.                 ps = con.prepareStatement("SELECT COUNT(*) FROM mts_items WHERE tab = ? " + listaitems + " AND type = ? AND transfer = 0");
  863.             } else {
  864.                 ps = con.prepareStatement("SELECT COUNT(*) FROM mts_items WHERE tab = ? " + listaitems + " AND transfer = 0");
  865.                 ps.setInt(1, tab);
  866.                 if (type != 0) {
  867.                     ps.setInt(2, type);
  868.                 }
  869.                 rs = ps.executeQuery();
  870.                 if (rs.next()) {
  871.                     pages = rs.getInt(1) / 16;
  872.                     if (rs.getInt(1) % 16 > 0) {
  873.                         pages += 1;
  874.                     }
  875.                 }
  876.                 rs.close();
  877.                 ps.close();
  878.             }
  879.         } catch (SQLException e) {
  880.             log.error("Err6: " + e);
  881.         }
  882.         return MaplePacketCreator.sendMTS(items, tab, type, page, pages);
  883.     }
  884. }