midclass教程-下.ipynb

{
 "cells": [
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "## 1.我们需要获取数据，但不需要一直获取数据\n",
    "## 2.我们需要做容错\n",
    "## 3.一些数据的处理不需要放在逻辑层里"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 2,
   "metadata": {},
   "outputs": [],
   "source": [
    "class mid_class():\n",
    "    def __init__(self, this_exchange):\n",
    "        '''\n",
    "        初始化数据填充交易所的信息，首次获取价格，首次获取account信息\n",
    "        设定好密钥……\n",
    "        \n",
    "        Args:\n",
    "            this_exchange: FMZ的交易所结构\n",
    "        \n",
    "        '''\n",
    "        self.init_timestamp = time.time()\n",
    "        self.exchange = this_exchange\n",
    "        self.name = self.exchange.GetName()\n",
    "        self.jyd = self.exchange.GetCurrency()        \n",
    "    \n",
    "    def get_account(self):\n",
    "        '''\n",
    "        获取账户信息\n",
    "        \n",
    "        Returns:\n",
    "            获取信息成功返回True，获取信息失败返回False\n",
    "        '''\n",
    "        self.Balance = '---'\n",
    "        self.Amount = '---'\n",
    "        self.FrozenBalance = '---'\n",
    "        self.FrozenStocks = '---'\n",
    "        \n",
    "        try:\n",
    "            self.account = self.exchange.GetAccount()\n",
    "\n",
    "            self.Balance =  self.account['Balance']\n",
    "            self.Amount = self.account['Stocks']\n",
    "            self.FrozenBalance =  self.account['FrozenBalance']\n",
    "            self.FrozenStocks = self.account['FrozenStocks']\n",
    "            return True\n",
    "        except:\n",
    "            return False\n",
    "    \n",
    "    def get_ticker(self):\n",
    "        '''\n",
    "        获取市价信息\n",
    "        \n",
    "        Returns:\n",
    "            获取信息成功返回True，获取信息失败返回False\n",
    "        '''\n",
    "        self.high = '---'\n",
    "        self.low = '---'\n",
    "        self.Sell =  '---'\n",
    "        self.Buy =  '---'\n",
    "        self.last =  '---'\n",
    "        self.Volume = '---'\n",
    "        \n",
    "        try:\n",
    "            self.ticker = self.exchange.GetTicker()\n",
    "        \n",
    "            self.high = self.ticker['High']\n",
    "            self.low = self.ticker['Low']\n",
    "            self.Sell =  self.ticker['Sell']\n",
    "            self.Buy =  self.ticker['Buy']\n",
    "            self.last =  self.ticker['Last']\n",
    "            self.Volume = self.ticker['Volume']\n",
    "            return True\n",
    "        except:\n",
    "            return False\n",
    "        \n",
    "        \n",
    "    def get_depth(self):\n",
    "        '''\n",
    "        获取深度信息\n",
    "        \n",
    "        Returns:\n",
    "            获取信息成功返回True，获取信息失败返回False\n",
    "        '''\n",
    "        self.Ask = '---'\n",
    "        self.Bids = '---'\n",
    "        \n",
    "        try:\n",
    "            self.Depth = self.exchange.GetDepth()\n",
    "            self.Ask = self.Depth['Asks']\n",
    "            self.Bids = self.Depth ['Bids']\n",
    "            return True\n",
    "        except:\n",
    "            return False\n",
    "        \n",
    "        \n",
    "    \n",
    "    def get_ohlc_data(self, period):\n",
    "        '''\n",
    "        获取K线信息\n",
    "        \n",
    "        Args:\n",
    "            period: K线周期，PERIOD_M1 指1分钟, PERIOD_M5 指5分钟, PERIOD_M15 指15分钟,\n",
    "            PERIOD_M30 指30分钟, PERIOD_H1 指1小时, PERIOD_D1 指一天。\n",
    "        '''\n",
    "        self.ohlc_data = exchange.GetRecords(period)\n",
    "        \n",
    "        \n",
    "    \n",
    "    def create_order(self, order_type, price, amount):\n",
    "        '''\n",
    "        post一个挂单信息\n",
    "        \n",
    "        Args:\n",
    "            order_type：挂单类型，'buy'指挂买单，'sell'指挂卖单\n",
    "            price：挂单价格\n",
    "            amount:挂单数量\n",
    "            \n",
    "        Returns:\n",
    "            挂单Id号，可用以取消挂单\n",
    "        '''\n",
    "        if order_type == 'buy':\n",
    "            try:\n",
    "                order_id = self.exchange.Buy( price, amount)\n",
    "            except:\n",
    "                return False\n",
    "            \n",
    "        elif order_type == 'sell':\n",
    "            try:\n",
    "                order_id = self.exchange.Sell( price, amount)\n",
    "            except:\n",
    "                return False\n",
    "        \n",
    "        return order_id\n",
    "    \n",
    "    def cancel_order(self, order_id):\n",
    "        '''\n",
    "        取消一个挂单信息\n",
    "        \n",
    "        Args:\n",
    "            order_id：希望取消的挂单ID号\n",
    "            \n",
    "        Returns:\n",
    "            取消挂单成功返回True，取消挂单失败返回False\n",
    "        '''\n",
    "        return self.exchange.CancelOrder(order_id)\n",
    "        \n",
    "    def refreash_data(self):\n",
    "        '''\n",
    "        刷新信息\n",
    "        \n",
    "        Returns:\n",
    "            刷新信息成功返回 'refreash_data_finish!' 否则返回相应刷新失败的信息提示\n",
    "        '''\n",
    "\n",
    "        if not self.get_account():\n",
    "            return 'false_get_account'\n",
    "        \n",
    "        if not self.get_ticker():\n",
    "            return 'false_get_ticker'\n",
    "        if not self.get_depth():\n",
    "            return 'false_get_depth'\n",
    "        try:\n",
    "            self.get_ohlc_data()\n",
    "        except:\n",
    "            return 'false_get_K_line_info'\n",
    "        \n",
    "        return 'refreash_data_finish!'\n"
   ]
  }
 ],
 "metadata": {
  "kernelspec": {
   "display_name": "Python [conda env:py37]",
   "language": "python",
   "name": "conda-env-py37-py"
  },
  "language_info": {
   "codemirror_mode": {
    "name": "ipython",
    "version": 3
   },
   "file_extension": ".py",
   "mimetype": "text/x-python",
   "name": "python",
   "nbconvert_exporter": "python",
   "pygments_lexer": "ipython3",
   "version": "3.5.4"
  }
 },
 "nbformat": 4,
 "nbformat_minor": 2
}