Support pull mode for JoinQuant

Author: sinall

.gitignore

@@ -89,3 +89,6 @@ ENV/
 .ropeproject
 
 .idea/
+examples/joinquant/config/config.ini
+tests/config/config.ini
+

README.md

@@ -16,8 +16,18 @@
 
 #### 步骤
 * 将 shipane_sdk/client.py 上传至聚宽“投资研究”根目录，并重命名为 shipane_sdk.py。
-* 将 shipane_sdk/joinquant_executor.py 追加到 shpane_sdk.py 中。
-* 用法请参考 examples/simply_joinquant_strategy.py (注意将其中的 xxx.xxx.xxx.xxx 替换为实际 IP)。
+* 将 shipane_sdk/joinquant/executor.py 追加到 shpane_sdk.py 中。
+* 用法请参考 examples/joinquant/simply_strategy.py (注意将其中的 xxx.xxx.xxx.xxx 替换为实际 IP)。
 
 ### 二. 抓取方式
-开发中
+无需云服务器，采用定时轮询的方式，实时性不如"推送方式"。
+
+#### 先决条件
+* 部署实盘易成功
+* 手动测试通过
+
+#### 步骤
+* git clone 或下载项目到本地。
+* 安装必要的依赖 "pip install requests"。
+* 参考 examples/joinquant/config/config.ini.template 创建 examples/joinquant/config/config.ini，并完善配置。
+* 命令行运行 "python ./examples/joinquant/simple_runner.py"。

examples/__init__.py

@@ -0,0 +1,9 @@
+[ShiPanE]
+host=localhost
+port=8888
+key=
+
+[JoinQuant]
+username=
+password=
+backtestId=

examples/joinquant/__init__.py

@@ -0,0 +1,28 @@
+# -*- coding: utf-8 -*-
+
+import ConfigParser
+import logging
+import os
+
+from shipane_sdk import Client
+from shipane_sdk.joinquant.client import JoinQuantClient
+from shipane_sdk.joinquant.runner import JoinQuantRunner
+
+if __name__ == "__main__":
+    logging.basicConfig(level=logging.INFO, format='%(asctime)-15s %(levelname)-6s %(message)s')
+
+    dir_path = os.path.dirname(os.path.realpath(__file__))
+
+    config = ConfigParser.RawConfigParser()
+    config.read('{}/config/config.ini'.format(dir_path))
+
+    shipane_client = Client(host=config.get('ShiPanE', 'host'),
+                            port=config.get('ShiPanE', 'port'),
+                            key=config.get('ShiPanE', 'key'))
+    jq_client = JoinQuantClient(username=config.get('JoinQuant', 'username'),
+                                password=config.get('JoinQuant', 'password'),
+                                backtest_id=config.get('JoinQuant', 'backtestId'))
+    jq_client.login()
+    runner = JoinQuantRunner(shipane_client, jq_client, interval=15)
+
+    runner.run()

examples/joinquant/config/config.ini.template

@@ -1,4 +1,4 @@
 # -*- coding: utf-8 -*-
 
 from .client import Client
-from .joinquant_executor import JoinQuantExecutor
+from .joinquant.executor import JoinQuantExecutor

examples/joinquant/simple_runner.py

@@ -75,6 +75,9 @@ def buy(self, symbol, price, amount):
     def sell(self, symbol, price, amount):
         return self.__execute('SELL', symbol, price, amount)
 
+    def execute(self, order_type, symbol, price, amount):
+        return self.__execute(order_type, symbol, price, amount)
+
     def cancel(self, order_id):
         return requests.delete(self.__create_order_url(order_id), timeout=self._timeout)