新增云存 短信及邮件提醒2

Controller/CloudStorage.py

@@ -1441,7 +1441,7 @@ class CloudStorageView(View):
                            'updTime': nowTime, 'uid': uid, 'eventType': 0}
             SysMsgModel.objects.create(**create_data)
 
-            user_qs = UserModel.objects.filter(id=userID)
+            user_qs = Device_User.objects.filter(userID=userID)
             if user_qs.exists():
                 user = user_qs[0]
                 username = user.username
@@ -1449,7 +1449,8 @@ class CloudStorageView(View):
                 if data_valid.email_validate(username):
                     S3Email.faEmail(sys_msg_text,username)
                 elif data_valid.mobile_validate(username):
-                    self.sendMessage(username)
+                    params = u'{"devname":"' + uid + '","submittime":"' + time.strftime("%Y-%m-%d",time.localtime()) + '"}'
+                    self.sendMessage(username, params, 'SMS_217405528')
 
                 self.pushApp(nowTime, uid, channel, sys_msg_text)
 
@@ -1489,7 +1490,7 @@ class CloudStorageView(View):
                         msg=sys_msg_text,
                         status=0
                     ))
-                    user_qs = UserModel.objects.filter(id=oo['userID_id'])
+                    user_qs = Device_User.objects.filter(userID=oo['userID_id'])
                     if user_qs.exists():
                         user = user_qs[0]
                         username = user.username
@@ -1498,7 +1499,9 @@ class CloudStorageView(View):
                         if data_valid.email_validate(username):
                             S3Email.faEmail(sys_msg_text, username)
                         elif data_valid.mobile_validate(username):
-                            self.sendMessage(username)
+                            params = u'{"devname":"' + ub['uid'] + '","submittime":"' + time.strftime("%Y-%m-%d",
+                                                                                                time.localtime()) + '"}'
+                            self.sendMessage(username, params, 'SMS_217425550')
 
                         self.pushApp(now_time, ub['uid'], ub['channel'], sys_msg_text)
 
@@ -1624,15 +1627,12 @@ class CloudStorageView(View):
                 print(res)
                 return res.status_code
 
-    def sendMessage(self, phone):
+    def sendMessage(self, phone , params, temp_msg):
             # 购买成功
-            temp_msg = 'SMS_217435193'
-            rec_phone = phone
             sign_ms = 'Ansjer'
-
             # 发送手机验证码
             aliSms = AliSmsObject()
-            res = aliSms.send_code_sms(phone=rec_phone, code='1', sign_name=sign_ms,
+            res = aliSms.send_code_sms_cloud(phone=phone, params = params, sign_name=sign_ms,
                                        temp_msg=temp_msg)
 
 

Object/AliSmsObject.py

@@ -76,6 +76,26 @@ class AliSmsObject(object):
         # {"Message":"OK","RequestId":"985FA027-C887-4186-A8F5-B6B8F3D123DB","BizId":"973407842937195533^0","Code":"OK"}
         # code = isv.BUSINESS_LIMIT_CONTROL 一分钟只能发一次
         return res_json
+
+        # 发送验证码
+
+    def send_code_sms_cloud(self, phone, params, sign_name, temp_msg):
+        __business_id = uuid.uuid1()
+        # print(__business_id)
+        # params = "{\"code\":\"{"+str(code)+"}\"}"
+        params = params
+        # params = u'{"name":"wqb","code":"12345678","address":"bz","phone":"13000000000"}'
+        # 签名
+        # sign_name = 'Ansjer'
+        # 模板信息
+        # temp_msg = 'SMS_151600991'
+        res = self.do_send_sms(__business_id, phone, sign_name, temp_msg, params)
+        # print(send_sms(__business_id, "13119657713", "云通信测试", "SMS_5250008", params))
+        res_json = json.loads(res.decode('utf-8'))
+        print(res_json)
+        # {"Message":"OK","RequestId":"985FA027-C887-4186-A8F5-B6B8F3D123DB","BizId":"973407842937195533^0","Code":"OK"}
+        # code = isv.BUSINESS_LIMIT_CONTROL 一分钟只能发一次
+        return res_json
 #
 # aliSms = AliSmsObject()
 # aliSms.send_sign_in_sms(phone=13119657713,code=123456)