|
@@ -13,6 +13,7 @@ import threading
|
|
|
import time
|
|
|
from decimal import Decimal
|
|
|
|
|
|
+from django.core.paginator import Paginator
|
|
|
from django.db import transaction
|
|
|
from django.db.models import Q
|
|
|
from django.views import View
|
|
@@ -505,7 +506,10 @@ class UnicomComboTaskView(View):
|
|
|
))
|
|
|
if not iot_card_list:
|
|
|
return None
|
|
|
- IotCardUsageHistory.objects.bulk_create(iot_card_list)
|
|
|
+ # 使用Django的Paginator进行分页
|
|
|
+ paginator = Paginator(iot_card_list, 300)
|
|
|
+ for page_num in range(1, paginator.num_pages + 1):
|
|
|
+ IotCardUsageHistory.objects.bulk_create(paginator.page(page_num).object_list)
|
|
|
except Exception as e:
|
|
|
logger.info('查询账期流量异常,errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
|
|
|
return None
|