-
Notifications
You must be signed in to change notification settings - Fork 2
/
4.快递查询kuaidi100.py
156 lines (142 loc) · 7.29 KB
/
4.快递查询kuaidi100.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
# -*- coding:utf-8 -*-
from flask import Flask
from flask import request
from flask import abort
import hashlib
import xmltodict
import time
import re
import requests
app = Flask(__name__)
@app.route("/")
def index():
return "Hello World!"
@app.route("/wechat", methods=["GET","POST"])
def weixin():
if request.method == "GET": # 判断请求方式是GET请求
my_signature = request.args.get('signature') # 获取携带的signature参数
my_timestamp = request.args.get('timestamp') # 获取携带的timestamp参数
my_nonce = request.args.get('nonce') # 获取携带的nonce参数
my_echostr = request.args.get('echostr') # 获取携带的echostr参数
if not all([my_signature, my_timestamp, my_nonce, my_echostr]):
abort(400)
token = "test123" #token验证
# 进行字典排序
data = [token,my_timestamp ,my_nonce ]
data.sort()
# 拼接成字符串
temp = ''.join(data)
# 进行sha1加密
mysignature = hashlib.sha1()
mysignature.update(temp.encode('utf-8'))
res = mysignature.hexdigest()
# 加密后的字符串可与signature对比，标识该请求来源于微信
if my_signature == res:
return my_echostr
else:
abort(403)
elif request.method == "POST": # 判断请求方式是POST请求
xml_str = request.data
if not xml_str:
abort(400)
# 对xml字符串进行解析
xml_dict = xmltodict.parse(xml_str)
xml_dict = xml_dict.get("xml")
# 提取消息类型
msg_type = xml_dict.get("MsgType")
if msg_type == "text":
# 表示发送的是文本消息
# 构造返回值，经由微信服务器恢复给用户的消息内容
content = xml_dict.get("Content")
if "天气" in content:
url = "https://www.tianqiapi.com/api/?version=v6&city="
b = content.strip("天气")
r='[’!"#$%&\'()*+,-./:;<=>?@[\\]^_`{|}~]+' # 正则删除标点符号
c=re.sub(r,'',b)
post = c.strip(" ")
appid = "&appid=1001&appsecret=5566" # 现在要appid或appsecret 否则报错
url_now = url + post + appid
rs_we = requests.get(url_now).json()
weather_city = rs_we["city"]
if weather_city == post:
weather_uptime = rs_we["date"] + " " + rs_we["week"] + " " + rs_we["update_time"] # 更新时间
weather_wea = rs_we["wea"] # 天气情况
weather_tem = rs_we["tem"] + "℃" # 当前温度
weather_temnow = rs_we["tem2"] + "/" + rs_we["tem1"] + "℃" # 早晚温差
weather_win = rs_we["win"] # 风向
weather_win_speed = rs_we["win_speed"] # 风速等级
weather_win_meter = rs_we["win_meter"] # 风速
weather_humidity = rs_we["humidity"] # 湿度
weather_visibility = rs_we["visibility"] # 能见度
weather_pressure = rs_we["pressure"] + "hPa" # 气压
weather_air = rs_we["air"] # 空气质量
weather_air_pm25 = rs_we["air_pm25"] # PM2.5
weather_air_level = rs_we["air_level"] # 空气质量等级
weather_info = weather_city + "-今日天气预报（实时）：" + "\r\n当前温度：" + weather_tem + "\r\n早晚温差：" + weather_temnow + "\r\n天气情况：" + weather_wea + "\r\n湿度：" + weather_humidity + "\r\n空气质量：" + weather_air + "\r\nPM2.5：" + weather_air_pm25 + "\r\n空气质量等级：" + weather_air_level + "\r\n气压：" + weather_pressure + "\r\n风向：" + weather_win + "\r\n风速：" + weather_win_meter + "\r\n风速等级：" + weather_win_speed + "\r\n能见度：" + weather_visibility + "\r\n更新时间：" + weather_uptime
resp_dict = {
"xml":{
"ToUserName": xml_dict.get("FromUserName"),
"FromUserName": xml_dict.get("ToUserName"),
"CreateTime": int(time.time()),
"MsgType": "text",
"Content": weather_info
}
}
else:
resp_dict = {
"xml":{
"ToUserName": xml_dict.get("FromUserName"),
"FromUserName": xml_dict.get("ToUserName"),
"CreateTime": int(time.time()),
"MsgType": "text",
"Content": "当前地区无法查询天气"
}
}
elif "快递查询" in content:
url = "https://m.kuaidi100.com/apicenter/kdquerytools.do?method=autoComNum&text="
b = content.strip("快递查询")
r='[’!"#$%&\'()*+,-./:;<=>?@[\\]^_`{|}~]+' # 正则删除标点符号
c=re.sub(r,'',b)
post = c.strip(" ")
if post == "":
resp_dict = {
"xml":{
"ToUserName": xml_dict.get("FromUserName"),
"FromUserName": xml_dict.get("ToUserName"),
"CreateTime": int(time.time()),
"MsgType": "text",
"Content": "注意快递查询格式（快递查询 单号）"
}
}
else:
url_now = url + post
rs_we = requests.get(url_now).json()
kd_message = rs_we["auto"]
if len(kd_message):
url2 = "https://m.kuaidi100.com/result.jsp?nu="
url_auto = url2 + post
resp_dict = {
"xml":{
"ToUserName": xml_dict.get("FromUserName"),
"FromUserName": xml_dict.get("ToUserName"),
"CreateTime": int(time.time()),
"MsgType": "text",
"Content": "快递单号" + post + "结果： \n<a href=\"" + url_auto +"\">点击查看物流</a>"
}
}
else:
resp_dict = {
"xml":{
"ToUserName": xml_dict.get("FromUserName"),
"FromUserName": xml_dict.get("ToUserName"),
"CreateTime": int(time.time()),
"MsgType": "text",
"Content": "无法识别当前单号"
}
}
# 将字典转换成为xml字符串
resp_xml_str = xmltodict.unparse(resp_dict)
# 返回消息数据给微信服务器
return resp_xml_str
if __name__ == "__main__":
app.run(host='0.0.0.0', port=80, debug=True)