ptrade 微信通知

对于节假日，ptrade经常会被暂停维护。 而有时候维护后需要你手动去重启策略。
 
所以情况多了，经常会忘记，手动登录进去重启。导致策略没有运行。
 
所以办法1，在盘前函数加入 微信通知，在交易日，如果盘前（8：30分左右），没有收到微信提醒，那么就需要即使登录到ptrade进行手动重启。
 
代码如下：

def notify(content=''):

    send_qywx(

        '微信id', '微信key', 'agent', info=content, 

        touser= '你的微信名字', 

        )

        

def before_trading_start(context, data):

    now = datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')

    notify('Ptrade 盘前运行{}'.format(now))

    

差不多这样就可以了。
 
不过笔者一般会使用另外一个种方式，因为如果哪一天没有收到，意味这ptrade没有起来，但你没有收到，你也就忘了这么一回事。 所以笔者的做法是，正常情况下不推送，而在ptrade不启动的时候才推送到微信。
 
下回更新。待续
 
# 继续更新
每天盘前，ptrade会到mysql插入一条数据，比如当天的日期
然后有个程序每天定时去读取mysql，如果读不到数据，就发送数据给微信即可。
 

class DBSelector():

    '''

    数据库选择类

    '''



    def get_engine(self):



        from sqlalchemy import create_engine

        try:

            engine = create_engine(

                'mysql+pymysql://{}:{}@{}:{}/{}?charset=utf8'.format(USER, PASSWORD, MYSQL_HOST, MYSQL_PORT, MYSQL_DB))

        except Exception as e:

            log.error(e)

            return None



        return engine



    def get_mysql_conn(self, db):

        import pymysql

        try:

            conn = pymysql.connect(host=MYSQL_HOST, port=MYSQL_PORT, user=USER, password=PASSWORD, db=db,

                                   charset='utf8')

        except Exception as e:

            log.error(e)

            return None

        else:

            return conn



def main():

    now = datetime.datetime.now()

    if not now.weekday():

        print('not week day')

        return



    db = DBSelector()

    conn = db.get_mysql_conn('ptrade')

    cursor = conn.cursor()

    sql_str = 'select count(*) from `ptrade_runing_status` where `date`=%s limit 1'

    date = now.strftime('%Y-%m-%d')

    cursor.execute(sql_str, (date,))

    result = cursor.fetchone()

    if result[0] == 0:

        send_message_via_wechat('{} ptrade没有启动！'.format(now))



if __name__=='__main__':

    main()