查询异常订单

AdminController/ServeManagementController.py

@@ -21,7 +21,7 @@ from Controller.UnicomCombo.UnicomComboTaskController import UnicomComboTaskView
 from Model.models import VodBucketModel, CDKcontextModel, Store_Meal, Order_Model, \
     UID_Bucket, ExperienceContextModel, Lang, CloudLogModel, UidSetModel, Unused_Uid_Meal, \
     Device_Info, DeviceTypeModel, UnicomComboOrderInfo, AiService, CountryModel, CouponLang, CouponConfigModel, \
-    CouponCombo, CouponModel, Device_User
+    CouponCombo, CouponModel, Device_User, AbnormalOrder
 from Object.ResponseObject import ResponseObject
 from Object.TokenObject import TokenObject
 from Object.UnicomObject import UnicomObjeect
@@ -120,6 +120,8 @@ class serveManagement(View):
 
             elif operation == 'getDeviceOrderList':
                 return self.getDeviceOrderList(request_dict, response)
+            elif operation == 'getAbnormalOrderList':
+                return self.getAbnormalOrderList(request_dict, response)
             elif operation == 'deleteDeviceOrder':
                 return self.deleteDeviceOrder(userID, request_dict, response)
             elif operation == 'getDevicePackageList':  # 云存设备套餐
@@ -1156,6 +1158,50 @@ class serveManagement(View):
             print(e)
             return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
 
+    def getAbnormalOrderList(self, request_dict, response):
+        print('request_dict: ', request_dict)
+        pageNo = request_dict.get('pageNo', None)
+        pageSize = request_dict.get('pageSize', None)
+        order_id = request_dict.get('order_id', None)
+        username = request_dict.get('username', None)
+        pay_type = request_dict.get('pay_type', None)
+        status = request_dict.get('status', None)
+        trade_no = request_dict.get('trade_no', None)
+        agreement_id = request_dict.get('agreement_id', None)
+        start_time = request_dict.get('start_time', None)
+        end_time = request_dict.get('end_time', None)
+
+        if not all([pageNo, pageSize]):
+            return response.json(444)
+
+        page = int(pageNo)
+        line = int(pageSize)
+        try:
+            order_qs = AbnormalOrder.objects.all()
+            # 筛选指定订单
+            if order_id:
+                order_qs = order_qs.filter(order_id=order_id)
+            if username:
+                order_qs = order_qs.filter(username=username)
+            if pay_type:
+                order_qs = order_qs.filter(pay_type=pay_type)
+            if status:
+                order_qs = order_qs.filter(status=status)
+            if trade_no:
+                order_qs = order_qs.filter(trade_no=trade_no)
+            if agreement_id:
+                order_qs = order_qs.filter(agreement_id=agreement_id)
+            if start_time and end_time:
+                order_qs = order_qs.filter(pay_time__gte=start_time, pay_time__lt=end_time)
+            if not order_qs.exists():
+                return response.json(0, [])
+            count = order_qs.count()
+            order_qs = order_qs.values("order_id", "username", "pay_type", "status", "trade_no", "agreement_id",
+                                       "price", "pay_time").order_by('-pay_time')[(page - 1) * line:page * line]
+            return response.json(0, {'list': list(order_qs), 'total': count})
+        except Exception as e:
+            return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
+
     def vodOrderReconcile(self, request, request_dict, response):
 
         file = request.FILES.get('file', None)