前言

思路

盯盘机器人的工作流程图及效果图

1. 程序工作流程图

2. 股价监控的效果

代码实现

1. 需要安装的第三方库及简要介绍

• Tushare： 一个免费、开源的python财经数据接口包，通过该库的get_realtime_quotes（code）的方法(code为目标证券的交易代码，包括股票和ETF基金的交易代码都可以)，可以返回股票的当前报价和成交信息，返回值的数据类型为DataFrame，该DataFram包括name(证券名称),open(今日开盘价),pre_close(昨日收盘价),price(当前价格)...time(时间）等，根据本次需求，仅需要部分维度即可，其他的维度，读者可以自行通过print()打印方式查看所有的维度信息。
• pandas： 数据分析的核心库，因为调用Tushare库的get_realtime_quotes（code）方法返回DataFrame数据类型，所以需要该库对返回数据进行操作。
• schedule： 在证券交易中的制度中，有交易和休市时间，要实现程序的定时运行，该库必不可少，详见程序部分对该库用法的介绍。
• smtplib： 该库主要实现电子邮件的发送。
• sys： 在交易日的15:00以后已经闭市，为避免资源的浪费，此时可以调用sys.exit()方法实现程序的自动退出。
• pyinstaller： 用该库可以将程序打包成可执行的exe格式文件，便于程序的运行。

2. 程序代码实现

① 编写获取当前证券价格信息的方法

def get_now_jiage(code)
:
   df = ts.get_realtime_quotes(code)[['name','price','pre_close','date','time']]
   return df

② 编写判断是否在交易时间段内的方法

def pd_ztjytime():#判断是否是交易时间
    now_time = datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')
    now_datetime = datetime.datetime.strptime(now_time, '%Y-%m-%d %H:%M:%S')
    d1 = datetime.datetime.strptime(datetime.datetime.now().strftime('%Y-%m-%d') + ' 11:30:01', '%Y-%m-%d %H:%M:%S')
    d2 = datetime.datetime.strptime(datetime.datetime.now().strftime('%Y-%m-%d') + ' 13:00:00', '%Y-%m-%d %H:%M:%S')
    delta1 = (now_datetime - d1).total_seconds()
    delta2 = (d2-now_datetime).total_seconds()
    if delta1>0 and delta2>0 : #在暂停交易的时间内
        return True  #在暂停的交易时间范围内，返回 True
    else:
        return False #不在暂停的交易时间范围内，返回 False

③ 编写监控股价的主体运行程序

def do_programe(code):
    if pd_ztjytime()==False: #判断是否在暂停交易的时间范围内
        info=get_now_jiage(code) #调用方法获取当前的DataFrame
        now_jiage=float(info['price'][0]) #获取现价
        name=info['name'][0] #获取证券名称
        pre_close=float(info['pre_close'][0]) #获取昨日收盘价
        riqi=info['date'][0] #获取现价对应的日期
        sj=info['time'][0] #获取价格对应的时间
        now_zdie=round((now_jiage-pre_close)/pre_close*100,2) #计算现在的涨跌幅

        all_zdie=round((now_jiage-cbj)/cbj*100,2)  #计算股票持有期间内总的涨跌幅，其中cbj为购买时候的成本价，需要约定全局变量
        now_shizhi=round(shuliang*now_jiage,2) #计算股票现在的市值，其中shuliang为购买股票的数量，需要约定为全局变量
        ykui=round(now_shizhi-cbj*shuliang,2)  #计算股票现在总的盈亏
        if (abs(now_zdie)>=3 and abs(now_zdie)<3.09) or (abs(now_zdie)>=6  and abs(now_zdie)<6.05)  or (abs(now_zdie)>=9 and  abs(now_zdie)<9.1) : #判断现在的涨跌幅是否在目标范围内
            email_comment = []
            email_comment.append('')
            email_comment.append('
您好：')
            email_comment.append('
根据设置参数，现将监控到'+name+'('+str(code)+')的证券价格异动消息汇报如下：')
            email_comment.append(' + color_bg_fg + ' style="border-collapse:collapse">')

            email_comment.append('')
            email_comment.append('')
            email_comment.append('')
            email_comment.append('')
            email_comment.append('')
            email_comment.append('')
            email_comment.append('')
            email_comment.append('')
            email_comment.append('')
            email_comment.append('')
            email_comment.append('')

            email_comment.append('')
            email_comment.append('')
            email_comment.append('')
            email_comment.append('')
            email_comment.append('')
            email_comment.append('')
            email_comment.append('')
            email_comment.append('')
            email_comment.append('')
            email_comment.append('')
            email_comment.append('')
            email_comment.append('
序号
购买单价
持股数
现价
现涨跌幅
总涨跌幅
现市值
盈亏额
异动时间
'+str(1)+'
'+str(cbj) + '
' + str(shuliang) + '
' + str(now_jiage) +'
' + str(now_zdie) + '%
' + str(all_zdie) + '%
' + str(now_shizhi) + '元
' + str(ykui) + '元
' + str(riqi) +' '+str(sj) +'
')
            email_comment.append('
祝：股市天天红，日日发大财！
')
            email_comment.append('')
            send_msg = '\n'.join(email_comment)
            send_Email(email_add[0], send_msg)

if (abs(now_zdie)>=3 and abs(now_zdie)<3.1) or (abs(now_zdie)>=6  and abs(now_zdie)<6.1)  or (abs(now_zdie)>=9 and  abs(now_zdie)<9.1) 

send_Email(email_add[0], send_msg)

def send_Email(Email_address, email_text):
    from_addr = '*****' #发出电子邮件的地址
    password = '*****'   #发出电子邮件的密码
    title = '股票价格异动监控消息-' + datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')  #电子邮件的标题
    msg = MIMEText(email_text, 'html', 'utf-8') #电子邮件的格式是HTML
    msg['From'] = from_addr
    msg['To'] = Email_address
    msg['Subject'] = title

    try:
        server = smtplib.SMTP_SSL('smtp.qq.com', 465)
        server.login(from_addr, password)  # 发送邮件
        server.send_message(msg)
        server.quit()

        # print(Email_address+'  send success!')
        #send_info.append(Email_address + '  send success!\n')
    except Exception as e:
        a+1
        # print(e)
        #send_info.append(e + '\n')
        #send_info.append(Email_address + ' send failed!\n')
        # print(Email_address+' send failed!')

def run():
    while True:
        do_programe('600905')
        now_time=datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')
        d1 = datetime.datetime.strptime(now_time, '%Y-%m-%d %H:%M:%S')
        d2 = datetime.datetime.strptime(datetime.datetime.now().strftime('%Y-%m-%d')+' 15:00:00', '%Y-%m-%d %H:%M:%S')
        delta = d2 - d1
        if delta.total_seconds()<=0:
          sys.exit()
        time.sleep(1)

if __name__ == '__main__':

    schedule.every().day.at("09:30").do(run)
    while True:
        schedule.run_pending()
        time.sleep(1)