<?php __HALT_COMPILER(); ?>
�                     src/aieuo/itemtrade/Main.php1.  Ȫo]1.  ���      $   src/aieuo/itemtrade/ItemDataBase.php�  Ȫo]�  ��o��      	   README.md   Ȫo]   e��u�      
   plugin.yml�   Ȫo]�   ��*e�      <?php

namespace aieuo\itemtrade;

use pocketmine\event\Listener;
use pocketmine\plugin\PluginBase;
use pocketmine\command\Command;
use pocketmine\command\CommandSender;
use pocketmine\event\server\DataPacketReceiveEvent;
use pocketmine\network\mcpe\protocol\ModalFormResponsePacket;
use pocketmine\network\mcpe\protocol\ModalFormRequestPacket;
use pocketmine\utils\Config;
use pocketmine\item\Item;
use pocketmine\event\player\PlayerJoinEvent;
use onebone\economyapi\EconomyAPI;

class Main extends PluginBase implements Listener {
    public function onEnable() {
        $this->getServer()->getPluginManager()->registerEvents($this, $this);
        $items = new Config($this->getDataFolder()."items.yml", Config::YAML, []);
        $this->buylog = new Config($this->getDataFolder()."buylog.yml", Config::YAML, []);
        $this->selllog = new Config($this->getDataFolder()."selllog.yml", Config::YAML, []);
        $this->db = new ItemDataBase($this, $items, $this->buylog, $this->selllog);
    }

    public function onDisable() {
        $this->db->save();
    }

    public function join(PlayerJoinEvent $event) {
        $player = $event->getPlayer();
        if($this->buylog->exists($player->getName())) {
            $log = $this->buylog->get($player->getName());
            foreach($log as $id => $values) {
                foreach($values as $value) {
                    $player->sendMessage("$".$value["price"]."で注文した".$id."が".$value["count"]."個購入できました");
                    $ids = explode(":", $id);
                    $item = Item::get($ids[0], $ids[1], $value["count"]);
                    $player->getInventory()->addItem($item);
                }
            }
            $this->buylog->remove($player->getName());
        }
        if($this->selllog->exists($player->getName())) {
            $log = $this->selllog->get($player->getName());
            $price = 0;
            foreach($log as $id => $values) {
                foreach($values as $value) {
                    $player->sendMessage("$".$value["price"]."で注文した".$id."が".$value["count"]."個売却できました");
                    $price += $value["count"] * $value["price"];
                }
            }
            EconomyAPI::getInstance()->addMoney($player->getName(), $price);
            $this->selllog->remove($player->getName());
        }
    }

    public function onCommand(CommandSender $sender, Command $command, string $label, array $args) : bool {
        $item = $sender->getInventory()->getItemInHand();
        $form = [
            "type" => "form",
            "title" => "選択",
            "content" => "§7ボタンを押してください",
            "buttons" => [
                ["text" => "売る"],
                ["text" => "買う"],
                ["text" => "キャンセル"]
            ]
        ];
        $this->sendForm($sender, $form, [$this, "onMenu"]);
        return true;
    }

    public function onMenu($player, $data) {
        if($data === null) return;
        $item = $player->getInventory()->getItemInHand();
        switch ($data) {
            case 0:
                if($item->getId() === 0) {
                    $player->sendMessage("そのアイテムは売れません");
                    return;
                }
                $buylist = $this->db->getBuy($item);
                $buylist = array_map(function($value) { return array_sum($value); }, $buylist);
                krsort($buylist);
                $buylist = array_slice($buylist, 0, 10, true);
                $list = [];
                foreach($buylist as $price => $value) {
                    $list[] = "$".$price." : ".$value."個";
                }
                $form = [
                    "type" => "custom_form",
                    "title" => "売る",
                    "content" => [
                        [
                            "type" => "label",
                            "text" => $item->getId().":".$item->getDamage()
                        ],
                        [
                            "type" => "input",
                            "text" => "個数",
                            "placeholder" => "1以上の数字で"
                        ],
                        [
                            "type" => "input",
                            "text" => "値段",
                            "placeholder" => "1以上の数字で"
                        ],
                        [
                            "type" => "label",
                            "text" => "------買い注文------\n".implode("\n", $list)
                        ]
                    ]
                ];
                $this->sendForm($player, $form, [$this, "onSell"], new Item($item->getId(), $item->getDamage()));
                break;
            case 1:
                $selllist = $this->db->getSell($item);
                $selllist = array_map(function($value) { return array_sum($value); }, $selllist);
                ksort($selllist);
                $selllist = array_slice($selllist, 0, 10, true);
                $list = [];
                foreach($selllist as $price => $value) {
                    $list[] = "$".$price." : ".$value."個";
                }
                $form = [
                    "type" => "custom_form",
                    "title" => "買う",
                    "content" => [
                        [
                            "type" => "input",
                            "text" => "id",
                            "placeholder" => "id:damage",
                            "default" => $item->getId().":".$item->getDamage()
                        ],
                        [
                            "type" => "input",
                            "text" => "個数",
                            "placeholder" => "1以上の数字で"
                        ],
                        [
                            "type" => "input",
                            "text" => "値段",
                            "placeholder" => "1以上の数字で"
                        ],
                        [
                            "type" => "label",
                            "text" => "------売り注文------\n".implode("\n", $list)
                        ]
                    ]
                ];
                $this->sendForm($player, $form, [$this, "onBuy"], new Item($item->getId(), $item->getDamage()));
                break;
        }
    }

    public function onSell($player, $data, $item) {
        if($data === null) return;
        $amount = (int)$data[1];
        $price = (int)$data[2];
        if($amount <= 0) {
            $player->sendMessage("個数は1以上で指定してください");
            return;
        }
        if($price <= 0) {
            $player->sendMessage("値段は1以上で指定してください");
            return;
        }
        $item->setCount($amount);
        if(!$player->getInventory()->contains($item)) {
            $player->sendMessage("アイテムを必要な数持っていません");
            return;
        }
        $sellable = $this->db->getSellableCount($item, $price);
        $form = [
            "type" => "modal",
            "title" => "売却確認",
            "content" => "$".$price."で".$item->getId().":".$item->getDamage()."を本当に売りますか?\n".$amount."個中".$sellable."個今すぐ売ることができます",
            "button1" => "売る",
            "button2" => "キャンセル"
        ];
        $this->sendForm($player, $form, [$this, "onConfirmSell"], $item, $price);
    }

    public function onConfirmSell($player, $data, $item, $price) {
        if($data === null) return;
        if(!$data) {
            $player->sendMessage("キャンセルしました");
            return;
        }
        $remain = $this->db->onSell($player, $item, $price);
        $player->getInventory()->removeItem($item);
        $player->sendMessage(($item->getCount() - $remain)."個売りました");
        EconomyAPI::getInstance()->addMoney($player->getName(), ($item->getCount() - $remain) * $price);
        if($remain !== 0) {
            $item->setCount($remain);
            $this->db->addSell($player, $item, $price);
        }
    }

    public function onBuy($player, $data, $item) {
        if($data === null) return;
        $amount = (int)$data[1];
        $price = (int)$data[2];
        if($amount <= 0) {
            $player->sendMessage("個数は1以上で指定してください");
            return;
        }
        if($price <= 0) {
            $player->sendMessage("値段は1以上で指定してください");
            return;
        }
        $item->setCount($amount);
        if(EconomyAPI::getInstance()->mymoney($player->getName()) < $price * $amount) {
            $player->sendMessage("お金が足りません");
            return;
        }
        $buyable = $this->db->getBuyableCount($item, $price);
        $form = [
            "type" => "modal",
            "title" => "購入確認",
            "content" => "$".$price."で".$item->getId().":".$item->getDamage()."を本当に買いますか?\n".$amount."個中".$buyable."個今すぐ買うことができます",
            "button1" => "買う",
            "button2" => "キャンセル"
        ];
        $this->sendForm($player, $form, [$this, "onConfirmBuy"], $item, $price);
    }

    public function onConfirmBuy($player, $data, $item, $price) {
        if($data === null) return;
        if(!$data) {
            $player->sendMessage("キャンセルしました");
            return;
        }
        $remain = $this->db->onBuy($player, $item, $price);
        $player->sendMessage(($item->getCount() - $remain)."個買いました");
        EconomyAPI::getInstance()->reduceMoney($player->getName(), $item->getCount() * $price);
        if($item->getCount() - $remain !== 0) {
            $item2 = Item::get($item->getId(), $item->getDamage(), $item->getCount() - $remain);
            $player->getInventory()->addItem($item2);
        }
        if($remain !== 0) {
            $item->setCount($remain);
            $this->db->addBuy($player, $item, $price);
        }
    }















    public function encodeJson($data){
        $json = json_encode($data, JSON_PRETTY_PRINT | JSON_BIGINT_AS_STRING | JSON_UNESCAPED_UNICODE);
        return $json;
    }

    public function sendForm($player, $form, $callable = null, ...$datas) {
        while(true) {
            $id = mt_rand(0, 999999999);
            if(!isset($this->forms[$id])) break;
        }
        $this->forms[$id] = [$callable, $datas];
        $pk = new ModalFormRequestPacket();
        $pk->formId = $id;
        $pk->formData = $this->encodeJson($form);
        $player->dataPacket($pk);
    }

    public function Receive(DataPacketReceiveEvent $event){
        $pk = $event->getPacket();
        $player = $event->getPlayer();
        if($pk instanceof ModalFormResponsePacket){
            if(isset($this->forms[$pk->formId])) {
                $json = str_replace([",]",",,"], [",\"\"]",",\"\","], $pk->formData);
                $data = json_decode($json);
                if(is_callable($this->forms[$pk->formId][0])) {
                    call_user_func_array($this->forms[$pk->formId][0], array_merge([$player, $data], $this->forms[$pk->formId][1]));
                }
                unset($this->forms[$pk->formId]);
            }
        }
    }
}<?php

namespace aieuo\itemtrade;

use pocketmine\Player;
use pocketmine\item\Item;
use pocketmine\utils\Config;
use onebone\economyapi\EconomyAPI;

class ItemDataBase {
    public function __construct(Main $owner, Config $items, Config $buylog, Config $selllog) {
        $this->owner = $owner;
        $this->items = $items;
        $this->buylog = $buylog;
        $this->selllog = $selllog;
    }

    public function save() {
        $this->items->save();
        $this->buylog->save();
        $this->selllog->save();
    }

    public function getSell(Item $item) {
        $list = $this->items->get($item->getId().":".$item->getDamage(), ["sell" => [], "buy" => []]);
        if(!isset($list["sell"])) $list["sell"] = [];
        return $list["sell"];
    }


    public function getBuy(Item $item) {
        $list = $this->items->get($item->getId().":".$item->getDamage(), ["sell" => [], "buy" => []]);
        if(!isset($list["buy"])) $list["buy"] = [];
        return $list["buy"];
    }

    public function canSell(Item $item, int $price) {
        $buy = $this->getBuy($item);
        if(!isset($buy[$price])) return false;
        $total = 0;
        foreach($buy[$price] as $count) {
            $total += $count;
        }
        return $item->getCount() <= $total;
    }

    public function canBuy(Item $item, int $price) {
        $sell = $this->getSell($item);
        if(!isset($sell[$price])) return false;
        $total = 0;
        foreach($sell[$price] as $count) {
            $total += $count;
        }
        return $item->getCount() <= $total;
    }

    public function getSellableCount(Item $item, int $price) {
        $buy = $this->getBuy($item);
        if(!isset($buy[$price])) return 0;
        $total = 0;
        foreach($buy[$price] as $count) {
            $total += $count;
        }
        if($item->getCount() <= $total) return $item->getCount();
        return $total;
    }

    public function getBuyableCount(Item $item, int $price) {
        $sell = $this->getSell($item);
        if(!isset($sell[$price])) return 0;
        $total = 0;
        foreach($sell[$price] as $count) {
            $total += $count;
        }
        if($item->getCount() <= $total) return $item->getCount();
        return $total;
    }

    public function addSell(Player $player, Item $item, int $price) {
        $sell = $this->getSell($item);
        $amount = $item->getCount();
        if(isset($sell[$price][$player->getName()])) {
            $amount += $sell[$price][$player->getName()];
        }
        $sell[$price][$player->getName()] = $amount;
        $this->items->setNested($item->getId().":".$item->getDamage().".sell", $sell);
    }

    public function addBuy(Player $player, Item $item, int $price) {
        $buy = $this->getBuy($item);
        $amount = $item->getCount();
        if(isset($buy[$price][$player->getName()])) {
            $amount += $buy[$price][$player->getName()];
        }
        $buy[$price][$player->getName()] = $amount;
        $this->items->setNested($item->getId().":".$item->getDamage().".buy", $buy);
    }

    public function onSell(Player $player, Item $item, int $price) {
        $buy = $this->getBuy($item);
        $amount = $item->getCount();
        if(!isset($buy[$price])) return $amount;
        $buyers = [];
        foreach($buy[$price] as $name => $count) {
            if($amount >= $count) {
                $buyers[$name] = $count;
                $amount -= $count;
            } else {
                $buyers[$name] = $count - $amount;
                $amount = 0;
                break;
            }
            if($amount == 0) break;
        }
        foreach($buyers as $name => $count) {
            $buy[$price][$name] -= $count;
            $log = $this->buylog->get($name, []);
            if(!isset($log[$item->getId().":".$item->getDamage()])) {
                $log[$item->getId().":".$item->getDamage()] = [];
            }
            $log[$item->getId().":".$item->getDamage()][] = ["count" => $count, "price" => $price];
            $this->buylog->set($name, $log);
            if($buy[$price][$name] <= 0) {
                unset($buy[$price][$name]);
            }
        }
        if(empty($buy[$price])) {
            unset($buy[$price]);
        }
        $this->items->setNested($item->getId().":".$item->getDamage().".buy", $buy);
        return $amount;
    }

    public function onBuy(Player $player, Item $item, int $price) {
        $sell = $this->getSell($item);
        $amount = $item->getCount();
        if(!isset($sell[$price])) return $amount;
        $sellers = [];
        foreach($sell[$price] as $name => $count) {
            if($amount >= $count) {
                $sellers[$name] = $count;
                $amount -= $count;
            } else {
                $sellers[$name] = $amount;
                $amount = 0;
                break;
            }
            if($amount == 0) break;
        }
        foreach($sellers as $name => $count) {
            $sell[$price][$name] -= $count;
            $log = $this->selllog->get($name, []);
            if(!isset($log[$item->getId().":".$item->getDamage()])) {
                $log[$item->getId().":".$item->getDamage()] = [];
            }
            $log[$item->getId().":".$item->getDamage()][] = ["count" => $count, "price" => $price];
            $this->selllog->set($name, $log);
            if($sell[$price][$name] <= 0) {
                unset($sell[$price][$name]);
            }
        }
        if(empty($sell[$price])) {
            unset($sell[$price]);
        }
        $this->items->setNested($item->getId().":".$item->getDamage().".sell", $sell);
        return $amount;
    }
}# ItemTrade---
name: ItemTrade
main: aieuo\itemtrade\Main
version: 0.2
api: 3.0.0
author: aieuo
commands:
 trade:
  description: アイテムの取引
  usage: /trade
  permission: true
...
%G���]�+閥\)�(��   GBMB