import
httplib
import
json
import
MySQLdb
access_token
=
""
try
:
conn
=
MySQLdb.connect(host
=
'192.168.1.1'
,user
=
'root'
,passwd
=
'root'
,db
=
'db_weixin'
,port
=
3306
)
cur
=
conn.cursor()
cur.execute(
'select access_token from weixin_public'
)
result
=
cur.fetchone()
access_token
=
result[
0
]
cur.close()
conn.close()
except
MySQLdb.Error,e:
print
"Mysql Error %d: %s"
%
(e.args[
0
], e.args[
1
])
if
not
access_token
is
None
:
conn
=
httplib.HTTPConnection(
"api.weixin.qq.com:80"
)
headers
=
{
"Content-type"
:
"application/json"
}
params
=
({
'touser'
:
"oEGZ4johnKOtayJbnEVeuaZr6zQ0"
,
'template_id'
:
'AtFuydv8k_15UGZuFntaBzJRCsHCkjNm1dcWD3A-11Y'
,
'url'
:
'http://www.jb51.net'
,
"topcolor"
:
"#667F00"
,#颜色
"data"
: {
"first"
: {
"value"
:
"尊敬的710.so : 您的网站http://www.jb51.net (192.168.1.1) 有异常访问"
,
"color"
:
"#173177"
},
"keyword1"
: {
"value"
:
"访问时间 2015-04-05 15:30:59 访问IP 192.168.1.2"
,
"color"
:
"#173177"
},
"keyword2"
: {
"value"
:
"访问链接 http://www.jb51.net"
,
"color"
:
"#173177"
},
"remark"
: {
"value"
:
"访问频率 10/s"
,
"color"
:
"#173177"
}
}
}
)
conn.request(
"POST"
,
"/cgi-bin/message/template/send?access_token="
+
access_token, json.JSONEncoder().encode(params), headers)
response
=
conn.getresponse()
data
=
response.read()
if
response.status
=
=
200
:
print
'success'
print
data
else
:
print
'fail'
conn.close()