添加注释

Controller/Cron/CronTaskController.py

@@ -325,23 +325,23 @@ class CronUpdateDataView(View):
     @classmethod
     def reqUpdateSerialStatus(cls, response):
         redis_obj = RedisObject()
-        # 更新已使用序列号其他服务器的状态
         logger = logging.getLogger('info')
-        used_serial_redis_list = redis_obj.lrange(USED_SERIAL_REDIS_LIST, 0, -1)
+        # 更新已使用序列号其他服务器的状态
+        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))
         if used_serial_redis_list:
             used_serial_redis_list = [str(i, 'utf-8') for i in used_serial_redis_list]
-            cls.do_request_thread(used_serial_redis_list, 3)
+            cls.do_request_function(used_serial_redis_list, 3)
         # 更新未使用序列号其他服务器的状态
-        unused_serial_redis_list = redis_obj.lrange(UNUSED_SERIAL_REDIS_LIST, 0, -1)
+        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))
         if unused_serial_redis_list:
             unused_serial_redis_list = [str(i, 'utf-8') for i in unused_serial_redis_list]
-            cls.do_request_thread(unused_serial_redis_list, 1)
+            cls.do_request_function(unused_serial_redis_list, 1)
         return response.json(0)
 
     @staticmethod
-    def do_request_thread(serial_redis_list, status):
+    def do_request_function(serial_redis_list, status):
         """
         请求更新序列号线程
         @param serial_redis_list: 序列号redis列表
@@ -357,15 +357,15 @@ class CronUpdateDataView(View):
         logger = logging.getLogger('info')
         logger.info('---请求更新序列号线程---data:{},orders_domain_name_list:{}'.format(data, orders_domain_name_list))
         try:
-            flag = 0
+            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)
                 result = response.json()
-                if result['result_code'] != 0:
+                if result['result_code'] != 0:  # 请求失败修改标志位
                     flag = 1
                     break
-            if flag == 0:
+            if flag == 0:  # 请求成功删除redis序列号
                 if status == 1:
                     for i in serial_redis_list:
                         redis_obj.lrem(UNUSED_SERIAL_REDIS_LIST, 0, i)