添加阿里云短信解耦

.gitignore

@@ -1,5 +1,4 @@
 *.html
 *.pyc
-*.yaml
 *.log
 .idea/

config/emailConf.py

@@ -5,7 +5,10 @@ __author__ = 'MR.wen'
 from email.header import Header
 from email.mime.text import MIMEText
 from config.ticketConf import _get_yaml
+# from ticketConf import _get_yaml
 import smtplib
+from aliyunsdkcore.client import AcsClient
+from aliyunsdkcore.request import CommonRequest
 
 
 def sendEmail(msg):
@@ -47,6 +50,38 @@ def sendEmail(msg):
     else:
         pass
 
+def sendmessage(ticketmseeage:str):
+    '''
+    短信通知，调用阿里云接口
+    '''
+    message_conf = _get_yaml()
+    is_email = message_conf["message_conf"]["is_massage"]
+    if is_email:
+        accessKeyId = message_conf["message_conf"]["aliyunkeyid"]
+        aliyunsecret = message_conf["message_conf"]["aliyunsecret"]
+        phonenumbers = message_conf["message_conf"]["phone"]
+        trcket = '{"code":"'+ticketmseeage+'"}'
+        client = AcsClient(accessKeyId,aliyunsecret, 'cn-hangzhou')
+        request = CommonRequest()
+        request.set_accept_format('json')
+        request.set_domain('dysmsapi.aliyuncs.com')
+        request.set_method('POST')
+        request.set_protocol_type('https') # https | http
+        request.set_version('2017-05-25')
+        request.set_action_name('SendSms')
+        request.add_query_param('RegionId', 'cn-hangzhou')
+        request.add_query_param('PhoneNumbers', phonenumbers)
+        request.add_query_param('SignName', '抢票小助手')
+        request.add_query_param('TemplateCode', 'SMS_164266405')
+        request.add_query_param('TemplateParam', trcket)
+        response = client.do_action(request)
+        # python2:  print(response) 
+        print(str(response, encoding = 'utf-8'))
+        try:
+            pass
+        except Exception as identifier:
+            print(u"短信发送失败{}".format(identifier))
 
 if __name__ == '__main__':
-    sendEmail(1)
+    # sendEmail(1)
+    sendmessage("Z50")

config/ticket_config.yaml

@@ -102,6 +102,14 @@ email_conf:
   password: ""
   host: "smtp.qq.com"
 
+#短信接口，用的是阿里云的短信接口
+message_conf:
+  is_massage: True
+  aliyunkeyid: "aliyunkeyid"
+  aliyunsecret: "aliyunsecret"
+  phone: 'phone'
+
+
 # 是否开启 pushbear 微信提醒， 使用前需要前往 http://pushbear.ftqq.com 扫码绑定获取 send_key 并关注获得抢票结果通知的公众号
 pushbear_conf:
   is_pushbear: False

inter/QueryOrderWaitTime.py

@@ -4,6 +4,7 @@ import time
 
 from config.TicketEnmu import ticket
 from config.emailConf import sendEmail
+from config.emailConf import sendmessage
 from config.pushbearConf import sendPushBear
 from myException.ticketIsExitsException import ticketIsExitsException
 from myException.ticketNumOutException import ticketNumOutException
@@ -45,6 +46,7 @@ class queryOrderWaitTime:
                             data.get("orderId", "")))
                         sendPushBear(ticket.WAIT_ORDER_SUCCESS.format(
                             data.get("orderId", "")))
+                        sendmessage(str(data.get("orderId", "")))
                         raise ticketIsExitsException(ticket.WAIT_ORDER_SUCCESS.format(
                             data.get("orderId")))
                     elif data.get("msg", False):