# !/usr/bin/env python
# -*- coding:utf-8 -*-
# Author:Hiuhung Wanfrom time import sleep
from dingtalkchatbot.chatbot import DingtalkChatbot
import tushare as tsts_code = "600036"  # 招商银行
webhook_prefix = "https://oapi.dingtalk.com/robot/send?access_token="
access_token = "这里输入自己钉钉机器人的access_token"
webhook = webhook_prefix + access_tokendef send_msg(msg):ding_robot = DingtalkChatbot(webhook)ding_robot.send_text(msg, is_at_all=0)def get_real_price(code):df = ts.get_realtime_quotes(code)name = df.name[0]price = df.price[0]price = round(float(price), 2)return name, pricedef price_comparison(profit_ceiling_price, stop_price, realtime_price, name):"""若高于则给钉钉发出卖出信号。如低于则发出买入信号！:param profit_ceiling_price: 止盈价格:param stop_price:           止损价格:param realtime_price:       实时价格:param name:                 股票名称:return: None"""if realtime_price > profit_ceiling_price:msg = "股票:%s ,现价:%s，看好就收，快抛！！" % (name, realtime_price)# print(msg)send_msg(msg)elif realtime_price < stop_price:msg = "股票:%s ,现价:%s，买买买！" % (name, realtime_price)send_msg(msg)# print(msg)def run2():msg = "因股市下班，价格不更新，为了达到价格有变，预先设置了几个价格"print(msg)# send_msg(msg)profit_ceiling_price = 34.0  # 止盈价格stop_price = 32.0            # 止损价格for i in [32.32,31.55,32.66,33.68,34.12,34.99,35.36,34.20,33.50,31.57,30.86]:name, price = get_real_price(ts_code)price = iprice_comparison(profit_ceiling_price, stop_price, price, name)# msg = "股票:%s ,现价:%s" % (name, price)# send_msg(msg)# print(msg)for j in range(10):sleep(1)def run():profit_ceiling_price = 33.0  # 止盈价格stop_price = 32.0            # 止损价格while True:name, price = get_real_price(ts_code)# msg = "股票:%s ,现价:%s" % (name, price)# send_msg(msg)# print(msg)price_comparison(profit_ceiling_price, stop_price, price, name)for j in range(10):sleep(1)if __name__ == '__main__':run()  # 正常就用这个# run2()  # 股市下班就用这个