This repository has been archived by the owner on Aug 10, 2023. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 2
/
HealthDataPost.py
207 lines (185 loc) · 9.24 KB
/
HealthDataPost.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
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
from urllib import parse
from lxml import etree
import requests
import time
import json
def getNowTime():
'''
获取当前已格式化的时间，格式：****-**-** **:**:**
:return: 返回格式化后的当前时间
'''
return time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())
class Student(object):
def __init__(self, ID, password, health_data_dict, SCKEY):
self.ID = ID
self.password = password
self.health_data_dict = health_data_dict
# 你的Server酱SCKEY
self.SCKEY = SCKEY
# 保持访问连接
self.session = requests.session()
def login(self):
'''
登录
:return: 返回登录的响应信息
'''
# 设置登录时所要的数据（账号——即学号和密码）
WebSite.login_data["username"] = self.ID
WebSite.login_data["password"] = self.password
# 登录
res0 = self.session.post(url=WebSite.login_api, data=WebSite.login_data, headers=WebSite.login_headers)
return res0
def submit(self):
'''
执行提交信息的动作
:return:
'''
# 提交
# 直接提交汉字可能会出错，URL编码处理
WebSite.submit_api_url_and_data = WebSite.submit_api_url + parse.urlencode(
self.health_data_dict)
# 设置提交数据api的请求头中的Referer
WebSite.submit_api_headers["Referer"] = WebSite.form_web_url
res = self.session.get(url=WebSite.submit_api_url_and_data, headers=WebSite.submit_api_headers)
return res
def serverChanPush(self, text, desp):
# Server酱通知服务
serverChan_res = requests.get(
'https://sc.ftqq.com/' + self.SCKEY + '.send?text=' + text + '&desp=' + "表单提交返回结果：" + desp)
return serverChan_res
def serverChanTurboPush(self, text, desp):
# Server酱通知服务
serverChan_res = requests.get(
'https://sctapi.ftqq.com/' + self.SCKEY + '.send?title=' + text + '&desp=' + "表单提交返回结果：" + desp)
return serverChan_res
def dataPost(self):
# 调用login方法进行登录
res0 = self.login()
if res0.status_code == 200:
# 登录成功
print(getNowTime() + " - 登录成功")
time.sleep(0.5)
# 设置表单页面的url和请求头中的Referer
# 无需设置url，直接访问即可
# WebSite.form_web_url = WebSite.form_web_url_head + cls.ID
WebSite.form_web_headers["Referer"] = WebSite.form_web_url
# 请求表单所在的网页
res1 = self.session.get(url=WebSite.form_web_url, headers=WebSite.form_web_headers).content.decode("UTF-8")
html1 = etree.HTML(res1)
# 这里的代码用于更新表单，正常每天首次提交用不到这些代码
# try:
# id = html1.xpath("//input[@name='did']/@value")[0]
# except IndexError:
# cls.health_data_dict["id"] = ""
# else:
# cls.health_data_dict["id"] = id
try:
# 查找提示信息
# 提取提示信息
prompt_info = html1.xpath("//div[@class='title']/text()")[0]
except IndexError:
# 如果没找到提示今天已经上报的信息而报错了，就初步判断今天还没上报
print("未找到是否上报的提示信息")
else:
# 没报错就代表提取到是否上报的提示信息了
# 去除提示信息前后的空格
prompt_info = prompt_info.strip()
# 根据提示信息判断是否提交
if "您已上报" not in prompt_info:
# 固定位置未找到已提交的提示信息
if ("您已上报" in res1) and ("健康信息" in res1):
# 如果固定位置没找到提示信息，但是网页其他地方找到了
print(getNowTime() + " - 警告：网站发生变化，推荐手动确认网页情况，以免发生错误")
else:
# 如果固定位置没找到提示信息，且网页源码都未发现相关提示
print(getNowTime() + " - 判断为还未提报今日身体信息")
time.sleep(1)
# 提交的准备工作，设置当前日期。
self.health_data_dict["fillDate"] = html1.xpath('/html//input[@name="ddate"]/@value')
# 提交动作
res = self.submit()
# 通过返回结果判断本次是否提交成功
if "OK" in res.text and res.status_code == 200:
print(getNowTime() + " - 本次提报成功，返回结果：" + res.text)
# 如果不为空，则进行推送通知
if self.SCKEY != "":
if self.SCKEY.startswith("SCU", 0, 3):
print(getNowTime() + " - 开始通过Server酱普通版推送消息")
ServerChan_res = self.serverChanPush("健康数据提交：本次提报【成功】！", res.text)
elif self.SCKEY.startswith("SCT", 0, 3):
print(getNowTime() + " - 开始通过Server酱Turbo版推送消息")
ServerChan_res = self.serverChanTurboPush("健康数据提交：本次提报【成功】！", res.text)
else:
print(getNowTime() + " - 未知类型的SCKEY/SendKey，请检查")
return
if ServerChan_res.status_code == 200:
print(getNowTime() + " - 已发送通知信息到Server酱：{}".format(ServerChan_res.text))
time.sleep(1)
print(getNowTime() + " - " + "提报结束")
else:
print(getNowTime() + " - 错误：本次提报失败，详情查看：" + res.text)
time.sleep(1)
print(getNowTime() + " - " + "提报结束")
else:
# 判断为已提交
print(getNowTime() + " - " + prompt_info)
time.sleep(1)
print(getNowTime() + " - " + "提报结束")
else:
print("登录出现异常")
class WebSite(object):
# 登录账户所用的数据
login_api = "http://sso.sdwcvc.cn/index.php?rid=verifyWebUser"
login_data = {}
login_headers = {
"User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/80.0.3987.116 Safari/537.36",
}
# 请求表单页面所要的数据
# form_web_url_head =
form_web_url = "http://pubinfo.sdwcvc.cn/xxtb2/dailyRecord"
form_web_headers = {
"Accept": "text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.9",
"Accept-Encoding": "gzip, deflate",
"Accept-Language": "zh-CN,zh;q=0.9,en-CN;q=0.8,en;q=0.7",
"Cache-Control": "max-age=0",
"Connection": "keep-alive",
# "Cookie": Cookie,
"Host": "pubinfo.sdwcvc.cn",
"Referer": "",
"Upgrade-Insecure-Requests": "1",
"User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/80.0.3987.116 Safari/537.36",
}
# 提交健康情况所要的数据
submit_api_url = "http://pubinfo.sdwcvc.cn/xxtb2/saveRecord?"
submit_api_url_and_data = ""
submit_api_headers = {
"Accept": "*/*",
"Accept-Encoding": "gzip, deflate",
"Accept-Language": "zh-CN,zh;q=0.9,en-CN;q=0.8,en;q=0.7",
"Connection": "keep-alive",
# "Cookie": Cookie,
"Host": "pubinfo.sdwcvc.cn",
"Referer": "",
"User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/80.0.3987.116 Safari/537.36",
"X-Requested-With": "XMLHttpRequest"
}
def main(a=1, b=1):
# ！！！！------------改成自己的学号和密码------------！！！！
# ！！！！-------外部健康文件要改成自己的-------！！！！
# 加载外部健康文件
health_file = open("students_data.json", "r", encoding="utf-8")
# 编码为python对象
students = json.loads(health_file.read())
len_students = len(students)
# print(len_students)
# 循环其列表中所有的学生
for student in students:
print("正在进行第{}/{}个用户".format(students.index(student) + 1, len_students))
# 创建学生实例
stu = Student(student["stu_id"], student["password"], student["health_data_dict"], student["SCKEY"])
stu.dataPost()
# 如果当前已经提交的学生信息不是最后一个，则延迟之后再进行提交下一个
if student != students[-1]:
time.sleep(2)
if __name__ == '__main__':
main()