diff --git a/ad_interface_tornado.py b/ad_interface_tornado.py
index 37dea57..5edb60c 100644
--- a/ad_interface_tornado.py
+++ b/ad_interface_tornado.py
@@ -22,173 +22,171 @@ limit = 3
 
 
 def send_cache_data():
-    mydb = MysqlBase(**mysql_promotion_config)
-    log.info("start update cache !")
-    now = datetime.datetime.today().strftime("%Y-%m-%d %H:%M:%S")
-    all = []
-    # 添加无天数限定的记录
-    get_full_data = f"select a.id,a.name,a.ad_num,a.ad_title,a.ad_body,a.ad_image,a.ad_url,a.ad_sort,a.companyid,a.locationid,a.gameid,b.appid from ad a,company b where a.companyid=b.id  and a.begin_time='{BEGIN}' or a.end_time='{END}'"
-    full_data = mydb.query(get_full_data)
+  mydb = MysqlBase(**mysql_promotion_config)
+  log.info("start update cache !")
+  now = datetime.datetime.today().strftime("%Y-%m-%d %H:%M:%S")
+  all = []
+  # 添加无天数限定的记录
+  get_full_data = f"select a.id,a.name,a.ad_num,a.ad_title,a.ad_body,a.ad_image,a.ad_url,a.ad_sort,a.companyid,a.locationid,a.gameid,b.appid from ad a,company b where a.companyid=b.id  and a.begin_time='{BEGIN}' or a.end_time='{END}'"
+  full_data = mydb.query(get_full_data)
 
-    if full_data:
-        for line in full_data:
-            if line:
-                log.info(f"line was {line}")
-                item = {}
-                try:
-                    item['id'], item['name'], item['ad_num'], item['ad_title'], item['ad_body'], item['ad_image'], item[
-                        'ad_url'], item['ad_sort'], item['companyid'], item['locationid'], item['gameid'], item[
-                        'appid'] = line
-                    all.append(item)
-                except Exception:
-                    log.error("split data failed", exc_info=True)
+  if full_data:
+    for line in full_data:
+      if line:
+        log.info(f"line was {line}")
+        item = {}
+        try:
+          item['id'], item['name'], item['ad_num'], item['ad_title'], item['ad_body'], item['ad_image'], item['ad_url'], \
+            item['ad_sort'], item['companyid'], item['locationid'], item['gameid'], item['appid'] = line
+          all.append(item)
+        except Exception:
+          log.error("split data failed", exc_info=True)
 
-    # 添加有天数限定的记录
-    get_data_sql = f"select a.id,a.name,a.ad_num,a.ad_title,a.ad_body,a.ad_image,a.ad_url,a.ad_sort,a.companyid,a.locationid,a.gameid,b.appid from ad a,company b where a.companyid=b.id and '{now}'>a.begin_time and '{now}'<a.end_time ;"
+  # 添加有天数限定的记录
+  get_data_sql = f"select a.id,a.name,a.ad_num,a.ad_title,a.ad_body,a.ad_image,a.ad_url,a.ad_sort,a.companyid,a.locationid,a.gameid,b.appid from ad a,company b where a.companyid=b.id and '{now}'>a.begin_time and '{now}'<a.end_time ;"
 
-    data = mydb.query(get_data_sql)
-    if data:
-        for line in data:
-            if line:
-                item = {}
-                try:
-                    item['id'], item['name'], item['ad_num'], item['ad_title'], item['ad_body'], item['ad_image'], item[
-                        'ad_url'], item['ad_sort'], item['companyid'], item['locationid'], item['gameid'], item[
-                        'appid'] = line
-                    all.append(item)
-                except Exception:
-                    log.error("split data failed", exc_info=True)
-    # 检查ID是否存在播放列表中，以及播放次数是否完毕
-    if all:
-        # log.info(f"get data was {all}!\n")
-        for line in all:
-            key = f"ad::{line.get('gameid', 0)}::{line.get('locationid', 0)}"
+  data = mydb.query(get_data_sql)
+  if data:
+    for line in data:
+      if line:
+        item = {}
+        try:
+          item['id'], item['name'], item['ad_num'], item['ad_title'], item['ad_body'], item['ad_image'], item['ad_url'], \
+            item['ad_sort'], item['companyid'], item['locationid'], item['gameid'], item['appid'] = line
+          all.append(item)
+        except Exception:
+          log.error("split data failed", exc_info=True)
+  # 检查ID是否存在播放列表中，以及播放次数是否完毕
+  if all:
+    # log.info(f"get data was {all}!\n")
+    for line in all:
+      key = f"ad::{line.get('gameid', 0)}::{line.get('locationid', 0)}"
 
-            if int(line['ad_num']) > 0:
-                num = my_redis.get(f"ad::{line['id']}::num")
-                if not num:
-                    num = 0
-                if int(line['ad_num']) > int(num):
-                    my_redis.sadd(key, line['id'])
-                    my_redis.expire(key, 120)
-                    n = int(line['ad_num']) - int(num)
-                    log.info(f"add {line['id']} to {key} ,num was {line['ad_num']},limit was {n}!")
-                else:
-                    if my_redis.sismember(key, line['id']):
-                        my_redis.srem(key, line['id'])
-                        log.info(f"remove {line['id']} from {key}!")
-            elif int(line['ad_num']) == 0:
-                my_redis.sadd(key, line['id'])
-                my_redis.expire(key, 120)
-                log.info(f"add {line['id']} to {key} ,num was unlimit !")
-            else:
-                log.error(f"get ad_num from mysql failed! ad_num={line['ad_num']}")
+      if int(line['ad_num']) > 0:
+        num = my_redis.get(f"ad::{line['id']}::num")
+        if not num:
+          num = 0
+        if int(line['ad_num']) > int(num):
+          my_redis.sadd(key, line['id'])
+          my_redis.expire(key, 120)
+          n = int(line['ad_num']) - int(num)
+          log.info(f"add {line['id']} to {key} ,num was {line['ad_num']},limit was {n}!")
+        else:
+          if my_redis.sismember(key, line['id']):
+            my_redis.srem(key, line['id'])
+            log.info(f"remove {line['id']} from {key}!")
+      elif int(line['ad_num']) == 0:
+        my_redis.sadd(key, line['id'])
+        my_redis.expire(key, 120)
+        log.info(f"add {line['id']} to {key} ,num was unlimit !")
+      else:
+        log.error(f"get ad_num from mysql failed! ad_num={line['ad_num']}")
 
-            if not my_redis.exists(f"ad::{line['id']}::info"):
-                my_redis.hmset(f"ad::{line['id']}::info", line)
-                my_redis.expire(f"ad::{line['id']}::info", 3600 * 24 * 7)
-                log.info(f"add ad::{line['id']}::info to redis!")
+      if not my_redis.exists(f"ad::{line['id']}::info"):
+        my_redis.hmset(f"ad::{line['id']}::info", line)
+        my_redis.expire(f"ad::{line['id']}::info", 3600 * 24 * 7)
+        log.info(f"add ad::{line['id']}::info to redis!")
 
-    # 删除过期的数据
-    log.info("remove expire data from cache!")
-    expire_sql = f"select id,gameid,locationid from ad where '{now}'>end_time"
-    remove_data = mydb.query(expire_sql)
-    if remove_data:
-        for line in remove_data:
-            try:
-                id, gameid, locationid = line
-                key = f"{gameid}:{locationid}"
-                if my_redis.sismember(key, id):
-                    my_redis.srem(key, id)
-                    log.info(f"remove {id} from {key} success!")
-            except Exception:
-                log.error("拆解过期数据出错!", exc_info=True)
+  # 删除过期的数据
+  log.info("remove expire data from cache!")
+  expire_sql = f"select id,gameid,locationid from ad where '{now}'>end_time"
+  remove_data = mydb.query(expire_sql)
+  if remove_data:
+    for line in remove_data:
+      try:
+        id, gameid, locationid = line
+        key = f"{gameid}:{locationid}"
+        if my_redis.sismember(key, id):
+          my_redis.srem(key, id)
+          log.info(f"remove {id} from {key} success!")
+      except Exception:
+        log.error("拆解过期数据出错!", exc_info=True)
 
 
 class DispatchHandler(tornado.web.RequestHandler):
 
-    def get(self):
-        if self.get_query_argument('c') == 'Ops' and self.get_query_argument('a') == 'selfChecking':
-            self._selfCheckingHandler()
-        elif self.get_query_argument('c') == 'Ops' and self.get_query_argument('a') == 'getAdList':
-            self._selfGetAdList()
-        elif self.get_query_argument('c') == 'Ops' and self.get_query_argument('a') == 'upAdRecording':
-            self._upAdRecording()
-        else:
-            self.write("pls check args!")
+  def get(self):
+    if self.get_query_argument('c') == 'Ops' and self.get_query_argument('a') == 'selfChecking':
+      self._selfCheckingHandler()
+    elif self.get_query_argument('c') == 'Ops' and self.get_query_argument('a') == 'getAdList':
+      self._selfGetAdList()
+    elif self.get_query_argument('c') == 'Ops' and self.get_query_argument('a') == 'upAdRecording':
+      self._upAdRecording()
+    else:
+      self.write("pls check args!")
 
-    def _upAdRecording(self):
+  def _upAdRecording(self):
+    try:
+      adid = self.get_query_argument('adid')
+    except Exception:
+      result = {'errcode': 2, "errmsg": f"get args failed`"}
+      log.error(result, exc_info=True)
+      self.write({'errcode': 1, "errmsg": 'get adid failed!'})
+
+    if adid:
+      key = f"ad::{adid}::num"
+      my_redis.incr(key, amount=1)
+      self.write({'errcode': 0, "errmsg": '', "message": f"{adid} incr success!"})
+
+
+  def _selfCheckingHandler(self):
+    self.write(json.dumps({
+      'errcode': 0, 'errmsg': '', 'healthy': 1, 'max_rundelay': 10
+      }, separators=(',', ':')))
+
+
+  def _selfGetAdList(self):
+    try:
+      input = json.loads(self.get_query_argument('body'))
+      gameid = input['gameid']
+      locationid = input['locationid']
+    except Exception as e:
+      result = {'errcode': 2, "errmsg": f"get args failed,{str(e)}"}
+      log.error(result)
+      self.write_error(2)
+      return False
+    if gameid and locationid:
+      key = f"ad::{gameid}::{locationid}"
+
+      ids = my_redis.smembers(key)
+      info = []
+      if not ids:
+        result = {'errcode': 0, "errmsg": '', "message": {"totoal": len(info), "result": info}}
+      else:
         try:
-            adid = self.get_query_argument('adid')
-        except Exception:
-            result = {'errcode': 2, "errmsg": f"get args failed`"}
-            log.error(result, exc_info=True)
-            self.write({'errcode': 1, "errmsg": 'get adid failed!'})
+          # 如果取得的记录条数大于预设，扔掉多余的记录,当前采用的是随机选择，以后可能需要添加加权选择
+          id_list = []
+          if limit < len(ids):
+            nums = limit
+          else:
+            nums = len(ids)
 
-        if adid:
-            key = f"ad::{adid}::num"
-            my_redis.incr(key, amount=1)
-            self.write({'errcode': 0, "errmsg": '', "message": f"{adid} incr success!"})
-
-
-    def _selfCheckingHandler(self):
-        self.write(json.dumps({
-            'errcode': 0, 'errmsg': '', 'healthy': 1, 'max_rundelay': 10
-            }, separators=(',', ':')))
-
-
-    def _selfGetAdList(self):
-        try:
-            input = json.loads(self.get_query_argument('body'))
-            gameid = input['gameid']
-            locationid = input['locationid']
+          for i in range(nums):
+            while 1:
+              new = my_redis.srandmember(key)
+              if new not in id_list:
+                id_list.append(new)
+                break
+          for id in id_list:
+            temp = my_redis.hgetall(f"ad::{id}::info")
+            info.append(temp)
+          result = {'errcode': 0, "errmsg": '', "message": {"totoal": len(info), "result": info}}
         except Exception as e:
-            result = {'errcode': 2, "errmsg": f"get args failed,{str(e)}"}
-            log.error(result)
-            self.write_error(2)
-            return False
-        if gameid and locationid:
-            key = f"ad::{gameid}::{locationid}"
-
-            ids = my_redis.smembers(key)
-            info = []
-            if not ids:
-                result = {'errcode': 0, "errmsg": '', "message": {"totoal": len(info), "result": info}}
-            else:
-                try:
-                    # 如果取得的记录条数大于预设，扔掉多余的记录,当前采用的是随机选择，以后可能需要添加加权选择
-                    id_list = []
-                    if limit < len(ids):
-                        nums = limit
-                    else:
-                        nums = len(ids)
-
-                    for i in range(nums):
-                        while 1:
-                            new = my_redis.srandmember(key)
-                            if new not in id_list:
-                                id_list.append(new)
-                                break
-                    for id in id_list:
-                        temp = my_redis.hgetall(f"ad::{id}::info")
-                        info.append(temp)
-                    result = {'errcode': 0, "errmsg": '', "message": {"totoal": len(info), "result": info}}
-                except Exception as e:
-                    result = {'errcode': 1, "errmsg": e}
-            self.write(result)
-        else:
-            result = {'errcode': 2, "errmsg": f"get args failed!"}
-            self.write(result)
+          result = {'errcode': 1, "errmsg": e}
+      self.write(result)
+    else:
+      result = {'errcode': 2, "errmsg": f"get args failed!"}
+      self.write(result)
 
 
 def make_app():
-    return tornado.web.Application([(r"/webapp/index[\.]php", DispatchHandler)])
+  return tornado.web.Application([(r"/webapp/index[\.]php", DispatchHandler)])
 
 
 if __name__ == "__main__":
-    print('start!')
-    send_cache_data()
-    app = make_app()
-    app.listen(ad_list_interface_port)
-    tornado.ioloop.PeriodicCallback(send_cache_data, 60000).start()
-    tornado.ioloop.IOLoop.current().start()
+  print('start!')
+  send_cache_data()
+  app = make_app()
+  app.listen(ad_list_interface_port)
+  tornado.ioloop.PeriodicCallback(send_cache_data, 60000).start()
+  tornado.ioloop.IOLoop.current().start()
diff --git a/handler/ad_image_upload.py b/handler/ad_image_upload.py
index b8c4c47..7508754 100644
--- a/handler/ad_image_upload.py
+++ b/handler/ad_image_upload.py
@@ -14,32 +14,32 @@ logging.basicConfig(level=logging.INFO, stream=sys.stdout)
 
 
 class Cos_sdk(Resource):
-	def __init__(self):
-		secret_id = os.environ.get('cos_id')
-		secret_key = os.environ.get('cos_key')
-		region = 'ap-beijing'  # 替换为用户的 Region
-		token = None  # 使用临时密钥需要传入 Token，默认为空，可不填
-		scheme = 'https'  # 指定使用 http/https 协议来访问 COS，默认为 https，可不填
-		config = CosConfig(Region=region, SecretId=secret_id, SecretKey=secret_key, Token=token, Scheme=scheme)
-		# 2. 获取客户端对象
-		self.client = CosS3Client(config)
-		self.bucket = "client-1256832210"
-		self.base_dirs = "/ad"
-		self.url = "https://resource.kingsome.cn"
+  def __init__(self):
+    secret_id = os.environ.get('cos_id')
+    secret_key = os.environ.get('cos_key')
+    region = 'ap-beijing'  # 替换为用户的 Region
+    token = None  # 使用临时密钥需要传入 Token，默认为空，可不填
+    scheme = 'https'  # 指定使用 http/https 协议来访问 COS，默认为 https，可不填
+    config = CosConfig(Region=region, SecretId=secret_id, SecretKey=secret_key, Token=token, Scheme=scheme)
+    # 2. 获取客户端对象
+    self.client = CosS3Client(config)
+    self.bucket = "client-1256832210"
+    self.base_dirs = "/ad"
+    self.url = "https://resource.kingsome.cn"
 
-	def post(self):
-		try:
-			import uuid
-			filename = "{}_{}".format(uuid.uuid1(), request.files.get('image-file').filename)
-			body = request.files.get('image-file').read()
-		except Exception as e:
-			error = f"get filename={filename},body={body} , 'error' = {e}"
-			return jsonify({'code': 500, 'message': error})
+  def post(self):
+    try:
+      import uuid
+      filename = "{}_{}".format(uuid.uuid1(), request.files.get('image-file').filename)
+      body = request.files.get('image-file').read()
+    except Exception as e:
+      error = f"get filename={filename},body={body} , 'error' = {e}"
+      return jsonify({'code': 500, 'message': error})
 
-		cos_filename = f"{self.base_dirs}/{filename}"
-		url = f"{self.url}/{cos_filename}"
+    cos_filename = f"{self.base_dirs}/{filename}"
+    url = f"{self.url}/{cos_filename}"
 
-		response = self.client.put_object(Bucket=self.bucket, Body=body, Key=cos_filename, StorageClass='STANDARD',
-		                                  EnableMD5=False)
-		print(response)
-		return jsonify({'code': 200, 'message': {'url': url, 'response': response}})
+    response = self.client.put_object(Bucket=self.bucket, Body=body, Key=cos_filename, StorageClass='STANDARD',
+                                      EnableMD5=False)
+    print(response)
+    return jsonify({'code': 200, 'message': {'url': url, 'response': response}})