Browse Source

优化同步序列号接口

peng 2 years ago
parent
commit
8f743f6645
1 changed files with 4 additions and 3 deletions
  1. 4 3
      Controller/Cron/CronTaskController.py

+ 4 - 3
Controller/Cron/CronTaskController.py

@@ -322,13 +322,13 @@ class CronUpdateDataView(View):
         logger = logging.getLogger('info')
         # 更新已使用序列号其他服务器的状态
         used_serial_redis_list = redis_obj.lrange(USED_SERIAL_REDIS_LIST, 0, -1)  # 读取redis已使用序列号
-        logger.info('---请求更新序列号接口---used_serial_redis_list:{}'.format(used_serial_redis_list))
+        logger.info('---请求更新序列号接口---used_serial_redis_list:{}---status:{}'.format(used_serial_redis_list, 3))
         if used_serial_redis_list:
             used_serial_redis_list = [str(i, 'utf-8') for i in used_serial_redis_list]
             cls.do_request_function(used_serial_redis_list, 3)
         # 更新未使用序列号其他服务器的状态
         unused_serial_redis_list = redis_obj.lrange(UNUSED_SERIAL_REDIS_LIST, 0, -1)  # 读取redis未使用序列号
-        logger.info('---请求更新序列号接口---unused_serial_redis_list:{}'.format(unused_serial_redis_list))
+        logger.info('---请求更新序列号接口---unused_serial_redis_list:{}---status:{}'.format(unused_serial_redis_list, 1))
         if unused_serial_redis_list:
             unused_serial_redis_list = [str(i, 'utf-8') for i in unused_serial_redis_list]
             cls.do_request_function(unused_serial_redis_list, 1)
@@ -354,7 +354,8 @@ class CronUpdateDataView(View):
             flag = 0  # 请求标志位
             for domain_name in orders_domain_name_list:
                 url = '{}cron/update/updateSerialStatus'.format(domain_name)
-                response = requests.post(url=url, data=data, timeout=2)
+                response = requests.post(url=url, data=data, timeout=5)
+                logger.info('---请求更新序列号响应时间---time:{}'.format(response.elapsed.total_seconds()))
                 result = response.json()
                 if result['result_code'] != 0:  # 请求失败修改标志位
                     flag = 1