|
@@ -8,6 +8,7 @@
|
|
# @File : CronTaskController.py
|
|
# @File : CronTaskController.py
|
|
# @Software: PyCharm
|
|
# @Software: PyCharm
|
|
import datetime
|
|
import datetime
|
|
|
|
+import logging
|
|
import threading
|
|
import threading
|
|
import time
|
|
import time
|
|
|
|
|
|
@@ -333,10 +334,15 @@ class CronUpdateDataView(View):
|
|
"""
|
|
"""
|
|
serial_redis_list = request_dict.get('serial_redis_list', None)
|
|
serial_redis_list = request_dict.get('serial_redis_list', None)
|
|
status = request_dict.get('status', None)
|
|
status = request_dict.get('status', None)
|
|
|
|
+ logger = logging.getLogger('info')
|
|
|
|
+ logger.info('---更新序列号状态参数---serial_redis_list:{},status:{}'.format(serial_redis_list, status))
|
|
if not all([serial_redis_list, status]):
|
|
if not all([serial_redis_list, status]):
|
|
return response.json(444)
|
|
return response.json(444)
|
|
- serial_redis_list = eval(serial_redis_list)
|
|
|
|
- CompanySerialModel.objects.filter(serial_number__in=serial_redis_list).update(status=int(status))
|
|
|
|
|
|
+ try:
|
|
|
|
+ serial_redis_list = eval(serial_redis_list)
|
|
|
|
+ CompanySerialModel.objects.filter(serial_number__in=serial_redis_list).update(status=int(status))
|
|
|
|
+ except Exception as e:
|
|
|
|
+ logger.info('---更新序列号状态异常---:{}'.format(repr(e)))
|
|
|
|
|
|
|
|
|
|
class CronCollectDataView(View):
|
|
class CronCollectDataView(View):
|