diff --git a/fooltrader/bot/actions.py b/fooltrader/bot/actions.py
index b183897..ef9a46a 100644
--- a/fooltrader/bot/actions.py
+++ b/fooltrader/bot/actions.py
@@ -8,6 +8,7 @@
 from email.mime.text import MIMEText
 
 import requests
+import schedule
 
 from fooltrader.settings import SMTP_HOST, SMTP_PORT, EMAIL_PASSWORD, EMAIL_USER_NAME, WEIXIN_APP_ID, WEIXIN_APP_SECRECT
 
@@ -56,6 +57,8 @@ class WeixinAction(Action):
     def __init__(self) -> None:
         self.refresh_token()
 
+        schedule.every(10).minutes.do(self.refresh_token())
+
     def refresh_token(self):
         resp = requests.get(self.GET_TOKEN_URL)
         self.logger.info("refresh_token resp.status_code:{}, resp.text:{}".format(resp.status_code, resp.text))
diff --git a/fooltrader/botsamples/notify_bot.py b/fooltrader/botsamples/notify_bot.py
index 4a00768..5f41003 100644
--- a/fooltrader/botsamples/notify_bot.py
+++ b/fooltrader/botsamples/notify_bot.py
@@ -96,7 +96,7 @@ def handle_trigger(self, trigger_flag, sub_id, subscription, current_price, chan
 
             triggered = True
 
-            self.logger.info(
+            self.logger.debug(
                 "send msg to user:{},price:{},change_pct:{}".format(subscription['userId'], current_price,
                                                                     change_pct))
 
diff --git a/fooltrader/connector/kafka_connector.py b/fooltrader/connector/kafka_connector.py
index ebc3bfe..108fd59 100644
--- a/fooltrader/connector/kafka_connector.py
+++ b/fooltrader/connector/kafka_connector.py
@@ -89,7 +89,7 @@ def cryptocurrency_tick_to_kafka(exchange, pairs=None):
                       bytes(json.dumps(tick), encoding='utf8'),
                       timestamp_ms=tick['timestamp'])
 
-        logger.info("tick_to_kafka {}".format(tick))
+        logger.debug("tick_to_kafka {}".format(tick))
 
 
 if __name__ == '__main__':
diff --git a/fooltrader/domain/subscription_model.py b/fooltrader/domain/subscription_model.py
index 57f7c5d..11201b9 100644
--- a/fooltrader/domain/subscription_model.py
+++ b/fooltrader/domain/subscription_model.py
@@ -15,8 +15,8 @@ class PriceSubscription(BaseDocType):
             "code": "BTC-USDT",
             "upPct": 1,
             "downPct": 2,
-            "upTo": 7000,
-            "downTo": 6000,
+            "up": 7000,
+            "down": 6000,
             "actions": ["weixin", "email", "shortMsg"],
             "repeat": False
         }
@@ -29,8 +29,8 @@ class PriceSubscription(BaseDocType):
     code = Keyword()
     upPct = Float()
     downPct = Float()
-    upTo = Float()
-    downTo = Float()
+    up = Float()
+    down = Float()
 
     repeat = Boolean()
     actions = Keyword()
diff --git a/fooltrader/domain/subscription_schema.py b/fooltrader/domain/subscription_schema.py
index e77a6ab..651ef42 100644
--- a/fooltrader/domain/subscription_schema.py
+++ b/fooltrader/domain/subscription_schema.py
@@ -13,8 +13,8 @@ class PriceSubscriptionSchema(Schema):
             "code": "BTC-USDT",
             "upPct": 1,
             "downPct": 2,
-            "upTo": 7000,
-            "downTo": 6000,
+            "up": 7000,
+            "down": 6000,
             "actions": ["weixin", "email", "shortMsg"],
             "repeat": False
         }
@@ -28,8 +28,8 @@ class PriceSubscriptionSchema(Schema):
     code = fields.Str()
     upPct = fields.Float()
     downPct = fields.Float()
-    upTo = fields.Float()
-    downTo = fields.Float()
+    up = fields.Float()
+    down = fields.Float()
 
     repeat = fields.Boolean(missing=False)
     actions = fields.List(fields.String)
diff --git a/requirements.txt b/requirements.txt
index 24175ae..e113b9d 100644
--- a/requirements.txt
+++ b/requirements.txt
@@ -29,4 +29,6 @@ ccxt == 1.14.224
 
 Flask == 1.0
 
-marshmallow
\ No newline at end of file
+marshmallow
+
+schedule
\ No newline at end of file