后台新增分页获取序列号绑定无限流量套餐、编辑接口

AdminController/UnicomManageController.py

@@ -14,7 +14,7 @@ from decimal import Decimal
 import openpyxl
 import requests
 from django.db import transaction, connection
-from django.db.models import Q
+from django.db.models import Q, F
 from django.http import HttpResponse
 from django.views.generic.base import View
 
@@ -105,6 +105,10 @@ class UnicomManageControllerView(View):
                 return self.iccid_batch_reset(tko.user, request, request_dict, response)
             elif operation == 'orderFlowPackage':  # 订购流量套餐包
                 return self.order_flow_package(request_dict, response, userID)
+            elif operation == 'getSerialNumberPackagePage':  # 订购流量套餐包
+                return self.serial_number_package_page(request_dict, response)
+            elif operation == 'serialNumberPackageUpdate':  # 订购流量套餐包
+                return self.serial_number_package_update(request_dict, response, tko.user)
             else:
                 return response.json(404)
 
@@ -118,7 +122,7 @@ class UnicomManageControllerView(View):
             package_id = request_dict.get('packageId', None)
             if not all([serial_number, package_id]):
                 return response.json(444)
-            u_device_info_qs = UnicomDeviceInfo.objects.filter(serial_no=serial_number, card_type=0)\
+            u_device_info_qs = UnicomDeviceInfo.objects.filter(serial_no=serial_number, card_type=0) \
                 .exclude(Q(user_id__isnull=True) | Q(user_id=''))
             if not u_device_info_qs.exists():
                 return response.json(173)
@@ -1128,3 +1132,65 @@ class UnicomManageControllerView(View):
             except Exception as e:
                 err_data.append({'serialNumber': serial_number, 'msg': '重置流量异常:{}'.format(repr(e))})
         return response.json(0, err_data)
+
+    @classmethod
+    def serial_number_package_page(cls, request_dict, response):
+        """
+        分页查询序列号无限流量套餐
+        """
+        serial_number = request_dict.get('serialNumber', None)
+        pageSize = request_dict.get('pageSize', None)
+        pageNo = request_dict.get('pageNo', None)
+        package_id = request_dict.get('packageId', None)
+
+        if not all({pageNo, pageSize}):
+            return response.json(444)
+        page = int(pageNo)
+        line = int(pageSize)
+        serial_package_qs = SerialNumberPackage.objects.all()
+        if serial_number:
+            serial_package_qs = serial_package_qs.filter(serial_number=serial_number)
+        if package_id:
+            serial_package_qs = serial_package_qs.filter(package_id=int(package_id))
+        serial_package_qs = serial_package_qs.annotate(serialNumber=F('serial_number'), packageId=F('package_id'),
+                                                       createdTime=F('created_time'), createdBy=F('created_by'),
+                                                       updatedTime=F('updated_time'), updatedBy=F('updated_by')) \
+            .values('id', 'serialNumber', 'status', 'packageId', 'createdTime', 'createdBy', 'updatedTime', 'updatedBy')
+        serial_package_qs = serial_package_qs.order_by('-created_time')[(page - 1) * line:page * line]
+        if not serial_package_qs.exists():
+            return response.json(0, [])
+        serial_list = []
+        for item in serial_package_qs:
+            data = item
+            data['packageName'] = UnicomCombo.objects.filter(id=item['packageId']).values('combo_name')[0]['combo_name']
+            serial_list.append(data)
+        return response.json(0, serial_list)
+
+    @classmethod
+    def serial_number_package_update(cls, request_dict, response, user):
+        """
+        修改序列号绑定无限流量套餐
+        """
+        try:
+            s_id = request_dict.get('id', None)
+            package_id = request_dict.get('packageId', None)
+            status = request_dict.get('status', None)
+            if not s_id:
+                return response.json(444)
+            if not package_id and not status:
+                return response.json(444)
+            s_package_qs = SerialNumberPackage.objects.filter(id=int(s_id))
+            if not s_package_qs.exists():
+                return response.json(173)
+            n_time = int(time.time())
+            data = {'updated_time': n_time, 'updated_by': user}
+            if package_id:
+                data['package_id'] = int(package_id)
+            if status:
+                data['status'] = int(status)
+            s_package_qs.update(**data)
+            return response.json(0)
+        except Exception as e:
+            LOGGER.info('UnicomManageControllerView.serial_number_package_update,'
+                        'errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
+            return response.json(500)

Ansjer/config.py

@@ -457,6 +457,8 @@ APP_TYPE = {
     2: 'android'
 }
 
+ALGORITHM_COMBO_TYPES = [51, 57, 58, 60, 59, 61, 62, 63, 64, 65, 66, 67, 68, 69]
+
 # 联通Unicom config
 # 应用地址，请向开发人员索取
 unicomAppUrl = 'https://iot-cop.unimip.cn'