|
@@ -327,6 +327,8 @@ class CronUpdateDataView(View):
|
|
|
redis_obj = RedisObject()
|
|
|
# 更新已使用序列号其他服务器的状态
|
|
|
used_serial_redis_list_len = redis_obj.llen(USED_SERIAL_REDIS_LIST)
|
|
|
+ logger = logging.getLogger('info')
|
|
|
+ logger.info('---请求更新序列号接口---used_serial_redis_len:{}'.format(used_serial_redis_list_len))
|
|
|
if used_serial_redis_list_len > 0:
|
|
|
used_serial_redis_list = []
|
|
|
for i in range(used_serial_redis_list_len):
|
|
@@ -335,6 +337,7 @@ class CronUpdateDataView(View):
|
|
|
request_thread.start()
|
|
|
# 更新未使用序列号其他服务器的状态
|
|
|
unused_serial_redis_list_len = redis_obj.llen(UNUSED_SERIAL_REDIS_LIST)
|
|
|
+ logger.info('---请求更新序列号接口---unused_serial_redis_len:{}'.format(unused_serial_redis_list_len))
|
|
|
if unused_serial_redis_list_len > 0:
|
|
|
unused_serial_redis_list = []
|
|
|
for i in range(unused_serial_redis_list_len):
|