优化业务类型汇总异常金额详情

app/api/export/crud.py

@@ -305,9 +305,11 @@ class ReferenceTypeClassification():
 
 class AbnormalDataDetails(object):
     """业务类型汇总异常数据详情"""
-    def __init__(self, date, reference_type):
+    def __init__(self, date, reference_type, page, size):
         self.date = 'assets_log_' + date
         self.reference_type = reference_type
+        self.page = page
+        self.size = size
 
     def abnormal_task(self):
         out_sql = f"select order_number from {self.date} where reference_type='{self.reference_type}' and type=0"
@@ -325,6 +327,6 @@ class AbnormalDataDetails(object):
         elif len(error_order_number) > 1:
             error_sql = f"select uuid,type,reference_type,reference_number,order_number,amount/1000 as amount,create_time from {self.date} where order_number in{tuple(error_order_number)}"
         else:
-            return []
+            return [], 0
         res = LinkMysql(env.DB_HISTORY).query_mysql(error_sql)
-        return res
+        return res[(self.page - 1) * self.size:self.page * self.size], len(res)

app/api/export/views.py

@@ -115,5 +115,5 @@ def abnormal_total(date: str, type: str, page: Optional[int] = None, size: Optio
     """异常数据详情"""
     if not all([date, type]):
         return HttpResultResponse(code=500, msg='缺少必传参数')
-    result = crud.AbnormalDataDetails(date, type).abnormal_task()
-    return HttpResultResponse(data=result)
+    result, tota = crud.AbnormalDataDetails(date, type, page, size).abnormal_task()
+    return HttpResultResponse(total=tota, data=result)

core/config/env.py

@@ -93,8 +93,8 @@ class ProdEnv(Env):
     CLEARING_CENTER_PORT: int = 5454
 
 
-# env = TestingEnv()  # 开发环境
-env = ProdEnv()         # 生产环境
+env = TestingEnv()  # 开发环境
+# env = ProdEnv()         # 生产环境
 
 redis_data = env.Redis
 pool = redis.ConnectionPool(host=redis_data.get("host"), port=redis_data.get("port"), password=redis_data.get("password"),