购买云存消息

Controller/CloudStorage.py

@@ -31,7 +31,7 @@ from django.views.generic.base import View
 from Ansjer.config import OSS_STS_ACCESS_KEY, OSS_STS_ACCESS_SECRET, OSS_ROLE_ARN, SERVER_DOMAIN, PAYPAL_CRD, \
     SERVER_DOMAIN_SSL, AWS_ACCESS_KEY_ID, AWS_SECRET_ACCESS_KEY, AWS_ARN
 from Model.models import Device_Info, Order_Model, Store_Meal, VodHlsModel, OssCrdModel, UID_Bucket, StsCrdModel, \
-    ExperienceContextModel, Pay_Type, CDKcontextModel, Device_User
+    ExperienceContextModel, Pay_Type, CDKcontextModel, Device_User, SysMassModel, SysMsgModel, UidPushModel
 from Object.AliPayObject import AliPayObject
 from Object.ResponseObject import ResponseObject
 from Object.TokenObject import TokenObject
@@ -776,6 +776,8 @@ class CloudStorageView(View):
                     dvq.update(**dvq_set_update_dict)
 
                 order_qs.update(status=1, updTime=nowTime, uid_bucket_id=uid_bucket_id)
+                sys_msg_text_list = {'成功购买云存', 'Successful purchase of cloud storage'}
+                do_vod_msg_Notice(UID, userid, sys_msg_text_list)
                 red_url = "{SERVER_DOMAIN}web/paid2/success.html".format(SERVER_DOMAIN=SERVER_DOMAIN)
                 return HttpResponseRedirect(red_url)
             return response.json(0, signature)
@@ -849,6 +851,8 @@ class CloudStorageView(View):
                 }
                 dvq.update(**dvq_set_update_dict)
             order_qs.update(status=1, updTime=nowTime, uid_bucket_id=uid_bucket_id)
+            sys_msg_text_list = {'成功购买云存','Successful purchase of cloud storage'}
+            do_vod_msg_Notice(UID, userid, sys_msg_text_list)
 
             # return response.json(0)
             red_url = "{SERVER_DOMAIN}web/paid2/success.html".format(SERVER_DOMAIN=SERVER_DOMAIN)
@@ -922,6 +926,8 @@ class CloudStorageView(View):
                     }
                     dvq.update(**dvq_set_update_dict)
                 order_qs.update(status=1, updTime=nowTime, uid_bucket_id=uid_bucket_id)
+                sys_msg_text_list = {'成功购买云存', 'Successful purchase of cloud storage'}
+                do_vod_msg_Notice(UID, userid, sys_msg_text_list)
                 return HttpResponse(pay.xml_to_dict({'return_code': 'SUCCESS', 'return_msg': 'OK'}))
 
             else:
@@ -1271,6 +1277,7 @@ class CloudStorageView(View):
         return response.json(444)
 
 
+
 # 删除过期云存播放列表
 def deleteVodHls(request):
     # UID = 'DSXG7481JVA2JM94111A'
@@ -1309,3 +1316,19 @@ def deleteExpiredUidBucket(request):
     id_list = expired_uid_bucket.values_list("id", flat=True)
     UID_Bucket.objects.filter(id__in=list(id_list)).delete()  # 删除过期云存关联套餐, 后续是否考虑用软删除
     return response.json(0)
+
+# 云存操作系统消息
+def do_vod_msg_Notice(uid, userID, sys_msg_text_list):
+    user = Device_User.objects.get(userID = userID)
+    lang = user.language;
+    if lang == 'cn':
+        sys_msg_text = sys_msg_text_list[0]
+    else:
+        sys_msg_text = sys_msg_text_list[1]
+    now_time = int(time.time())
+    SysMsgModel.objects.create(userID_id=userID,
+        msg=sys_msg_text,
+        addTime=now_time,
+        updTime=now_time,
+        uid=uid,
+        eventType=0)