后台增加获取套餐列表

生成cdk接口增加参数套餐id

AdminController/ServeManagementController.py

@@ -80,6 +80,8 @@ class serveManagement(View):
                 return self.getCdkList(userID, request_dict, response)
             elif operation == 'createCdk':
                 return self.createCdk(request_dict, response)
+            elif operation == 'getVodStoreMeal':
+                return self.getVodStoreMeal(response)
             elif operation == 'deleteCdk':
                 return self.deleteCdk(request_dict, response)
             elif operation == 'downloadCDK':
@@ -573,23 +575,36 @@ class serveManagement(View):
             print(e)
             return response.json(500, repr(e))
 
+    def getVodStoreMeal(self, response):
+        try:
+            store_meal = Store_Meal.objects.filter(Q(is_show=0), ~Q(commodity_code='paypal_cycle'), Q(lang__lang='cn')).annotate(
+                title=F('lang__title')).values('id', 'title')
+            if not store_meal.exists():
+                return response.json(0, [])
+            return response.json(0, list(store_meal))
+        except Exception as e:
+            return response.json(500, repr(e))
+
     def createCdk(self, request_dict, response):
         cdk_num = request_dict.get("cdknum", None)
         mold = request_dict.get('mold', None)
         order = request_dict.get('order', None)
-        cdk_list = []
-        sm_qs = Store_Meal.objects.filter(
-            pay_type__payment='cdk_pay', bucket__mold=mold, is_show=0)
-        if not sm_qs.exists():
+        rank = request_dict.get('rank', None)
+        if not all([cdk_num, rank]):
+            return response.json(444, {'error param': 'cdknum or rank'})
+        store_meal = Store_Meal.objects.filter(rank=rank)
+        # sm_qs = Store_Meal.objects.filter(
+        #     pay_type__payment='cdk_pay', bucket__mold=mold, is_show=0)
+        if not store_meal.exists():
             return response.json(173)
-        rank = sm_qs[0].id
+        cdk_list = []
         for i in range(int(cdk_num)):
-            nowTime = int(time.time())
+            now_time = int(time.time())
             cdk = hashlib.md5((str(uuid.uuid1()) +
-                               str(nowTime)).encode('utf-8')).hexdigest()
+                               str(now_time)).encode('utf-8')).hexdigest()
             cdk_model = CDKcontextModel(
                 cdk=cdk,
-                create_time=nowTime,
+                create_time=now_time,
                 valid_time=0,
                 is_activate=0,
                 is_down=0,
@@ -711,21 +726,21 @@ class serveManagement(View):
                     'order_type': order['order_type'],
                 }
                 #  订单显示(或不显示)停用/退款功能
-                if order['order_type'] == 0: # 云存
+                if order['order_type'] == 0:  # 云存
                     uid_bucket = UID_Bucket.objects.filter(uid=order['UID']).values('use_status')
                     user_status = uid_bucket[0]['use_status'] if uid_bucket.exists() else ''
                     if user_status != '':
                         data['user_status'] = user_status
                     else:
                         data['user_status'] = 2
-                elif order['order_type'] == 1: # ai
+                elif order['order_type'] == 1:  # ai
                     ai_service_qs = AiService.objects.filter(
                         Q(orders_id=order['orderID']) & ~Q(use_status=2))
                     if ai_service_qs.exists():
                         data['user_status'] = 1
                     else:
                         data['user_status'] = 2
-                elif order['order_type'] == 2: # 联通4G
+                elif order['order_type'] == 2:  # 联通4G
                     unicom_combor_order_qs = UnicomComboOrderInfo.objects.filter(
                         Q(order_id=order['orderID']) & ~Q(status=2))
                     if unicom_combor_order_qs.exists():