tt

Controller/CloudVod.py

@@ -195,7 +195,10 @@ class CloudVodView(View):
         channel = utko.channel
         print(channel)
         print(UID)
-        qs = Device_Meal.objects.filter(uid=UID, channel=channel, status=1).values("rank", "channel")
+        qs = Device_Meal.objects.filter(uid=UID, channel=channel, status=1).values("rank", "channel", "end_time")
+        now_time = timezone.localtime(timezone.now())
+        if now_time > qs[0]['end_time']:
+            return response.json(10, '已过期')
         if not qs.exists():
             return response.json(10, '设备未购买')
         # 套餐id
@@ -278,7 +281,10 @@ class CloudVodView(View):
         if not qs.exists():
             return response.json(13)
         uid = qs[0]['UID']
-        dm_qs = Device_Meal.objects.filter(uid=uid, channel=channel).values('rank')
+        dm_qs = Device_Meal.objects.filter(uid=uid, channel=channel).values('rank', 'end_time')
+        now_time = timezone.localtime(timezone.now())
+        if now_time > dm_qs[0]['end_time']:
+            return response.json(10, '已过期')
         if not dm_qs.exists():
             return response.json(10, '未开通云存储')
         rank = dm_qs[0]["rank"]
@@ -300,10 +306,7 @@ class CloudVodView(View):
                 url_start = urllib.parse.unquote(urllst[0])
                 url_end = urllst[1]
                 vod_play_url = '{url_start}?{url_end}'.format(url_start=url_start, url_end=url_end)
-                vod_play_list.append({
-                    'name': ptime,
-                    'sign_url': vod_play_url
-                })
+                vod_play_list.append({'name': ptime, 'sign_url': vod_play_url})
             else:  # 文件
                 pass
                 print('file: ' + obj.key)
@@ -366,6 +369,9 @@ class CloudVodView(View):
             return response.json(10, '没有设备')
         UID = dvqs[0]["UID"]
         dmqs = Device_Meal.objects.filter(channel=channel, uid=UID)
+        now_time = timezone.localtime(timezone.now())
+        if now_time > dmqs[0].end_time:
+            return response.json(10, '已过期')
         if not dmqs.exists():
             return response.json(10, '未购买')
         now_time = timezone.localtime(timezone.now())
@@ -374,7 +380,9 @@ class CloudVodView(View):
         utko.generate(data={'uid': UID, 'channel': channel})
         uidTkUrl = "{SERVER_DOMAIN}cloudVod/getSts?uidToken={uidToken}".format(uidToken=utko.token,
                                                                                SERVER_DOMAIN=SERVER_DOMAIN)
-        return response.json(0, uidTkUrl)
+        return response.json(0, {
+            'uidTkUrl':uidTkUrl
+        })
 
     def do_store_palylist(self, request_dict, response):
         uidToken = request_dict.get('uidToken', None)