自带简易demo移入相应包内

qqrobot/__init__.py

@@ -1,2 +1,74 @@
 #!/usr/bin/python
 # coding: utf-8
+
+import sys
+# sys.path.insert(0, "..")
+import time
+from threading import Thread
+
+from qqrobot.core.qsession import BaseSession
+
+# TODO:
+#   - celery 一直有问题，提交任务之后 worker 执行报错，待解决，暂时用线程代替
+# from celeryMQ.app import qqrobotMQ
+
+bot = BaseSession()
+
+# @qqrobotMQ.task
+# def add(x, y):
+#     return x + y
+#
+# @qqrobotMQ.task
+# def async_send_msg(msg, from_uin, msg_type, *args, **kw):
+#     bot.send_msg(msg, from_uin, msg_type, *args, **kw)
+
+def async_send_msg(msg, from_uin, msg_type, *args, **kw):
+    Thread(target=bot.send_msg,
+          args=(msg, from_uin, msg_type, args, kw)).start()
+
+
+def run():
+    global bot
+    bot.log.info("扫描二维码")
+    bot.get_QRcode()
+    IS_LOGIN = False
+    while not IS_LOGIN:
+        time.sleep(1.5)
+        res = bot.is_login().split(',')[-2]
+        bot.log.info(res)
+        IS_LOGIN = True if '登录成功' in res else False
+    bot.log.info('获取ptwebqq...')
+    bot.get_ptwebqq()
+    bot.log.info('获取vfwebqq...')
+    bot.get_vfwebqq()
+    bot.log.info('获取psessionid...')
+    bot.get_psessionid()
+    bot.log.info('等待消息...')
+    STOP, IS_OPEN = False, True
+    while not STOP:
+        time.sleep(1)
+        try:
+            msg = bot.poll()
+            if msg:
+                msg_content, from_uin, msg_type = msg
+            else:
+                continue
+            if (IS_OPEN is True) and ('STOP' not in msg_content):
+                # msg = "{0}[{1}]".format(SEND_MSG, random.randint(0, 10))
+                # send_status = bot.send_msg(msg, from_uin, msg_type)
+                # LOG.info('回复 {0}: {1}'.format(from_uin, send_status))
+                # async_send_msg.delay(msg_content, from_uin, msg_type)
+                async_send_msg(msg_content, from_uin, msg_type)
+            elif 'STOP' in msg_content:
+                bot.log.info('CLOSE...')
+                async_send_msg('CLOSED', from_uin, msg_type)
+                IS_OPEN = False
+            elif 'START' in msg_content:
+                bot.log.info('STARTED')
+                async_send_msg('OPENED', from_uin, msg_type)
+                IS_OPEN = True
+        except KeyboardInterrupt:
+            bot.log.info('See You...')
+            STOP = True
+        except:
+            bot.log.error(sys.exc_info())