-
Notifications
You must be signed in to change notification settings - Fork 1
/
HKstock_on_time.py
110 lines (85 loc) · 3.26 KB
/
HKstock_on_time.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
# ! -*- coding:utf-8 -*-
# 2019.1.23 增加index部位的手数部分
import time
import re
import pymysql
import requests
from lxml import etree
import time
import datetime
from math import floor
# 2019.1.13 中国燃气-恒生指数
total_Cash = 100000 # 10万港元
index_Cash = 0.3*total_Cash
stock_Cash = 0.6*total_Cash
index_Future_N = floor(index_Cash/26666) # index部位是港元，每手保证金也是港元，不用汇率换算
index_cost = 26666
stock_cost = 26.1
def get_index_PL():
response = requests.get('https://www.laohu8.com/hq/s/HSI?f=baidu&utm_source=baidu&utm_medium=aladingpc')
html = response.text
selector = etree.HTML(html)
price = selector.xpath('//*[@id="root"]/div/div[2]/div[2]/div[1]/div/div[1]/div[1]/div/strong/text()')
items_float = float(price[0])
indexF_PL = (index_cost-items_float)*10*index_Future_N # index部位，价差，乘以每点10港元，再乘以手数，最终是港元的盈亏
indexF_PL_2 = round(indexF_PL,2)
big_list.append(str(indexF_PL_2))
# 00384 中国燃气 25.4
def get_stocks_PL():
response = requests.get('https://www.laohu8.com/hq/s/00384')
html = response.text
selector = etree.HTML(html)
price = selector.xpath('//*[@id="root"]/div/div[2]/div[2]/div[1]/div/div[1]/div[1]/div/strong/text()')
stock_PL = ((float(price[0]) - stock_cost)/stock_cost) *stock_Cash # 用股价套算出涨跌幅，乘上stock部位资金即可，也是港元盈亏
stock_PL_2 = round(stock_PL,2)
big_list.append(stock_PL_2)
def profilo_PL():
try:
A = big_list[0]
B = big_list[1]
profilo_PL = float(B) + float(A)
profilo_PL_2 = round(profilo_PL,2)
big_list.append(profilo_PL_2)
total_profit_R = profilo_PL_2/total_Cash
# total_profit_R_2 = '%.2f%%' % (total_profit_R * 100) 这个是为加上 ％
total_profit_R_2 = round(total_profit_R,3) * 100 # 这个最简单
big_list.append(total_profit_R_2)
except IndexError as e:
print(e)
def insertDB(content):
connection = pymysql.connect(host='127.0.0.1', port=3306, user='root', password='123456', db='web_monitor',
charset='utf8mb4', cursorclass=pymysql.cursors.DictCursor)
cursor = connection.cursor()
# 这里是判断big_list的长度，不是content字符的长度
if len(big_list) == 4:
cursor.executemany('insert into MHI_OneStock_PL (index_PL,stock_PL,profilo_PL,profilo_PL_R) values (%s,%s,%s,%s)', content)
connection.commit()
connection.close()
print('向MySQL中添加数据成功！')
else:
print('出列啦')
#
#
if __name__ == '__main__':
while True:
big_list = []
get_index_PL()
get_stocks_PL()
profilo_PL()
l_tuple = tuple(big_list)
content = []
content.append(l_tuple)
insertDB(content)
time.sleep(10)
print(datetime.datetime.now())
# 指数期货盈亏， 个股盈亏，总盈亏， 总收益率 这个四个部分进行设计
#
#
# create table MHI_OneStock_PL(
# id int not null primary key auto_increment,
# index_PL varchar(10),
# stock_PL varchar(10),
# profilo_PL varchar(10),
# profilo_PL_R varchar(10)
# ) engine=InnoDB charset=utf8;
# drop table MHI_OneStock_PL;