diff --git a/bi/vas_yoy_flow.py b/bi/vas_yoy_flow.py
index 0af0296..8f93112 100644
--- a/bi/vas_yoy_flow.py
+++ b/bi/vas_yoy_flow.py
@@ -22,7 +22,7 @@ class S:
         rows = self.mysql_db_bi.query(sql)
         if len(rows) > 0:
             dt = rows[0].get("ptime")
-            return dt.timestamp()
+            return int(dt.timestamp())
         return 0
 
     def get_flow(self, st, et):
@@ -33,13 +33,16 @@ class S:
         return 0
 
     def proc(self):
+        time_now = int(time.time())
         zero_time = get_today_zero_time() - 86400
-        last_ptime = self.get_last_ptime()
-        if last_ptime == 0:
-            return
+        last_time = self.get_last_ptime()
 
-        print(zero_time)
-        print(last_ptime, type(last_ptime))
+        while last_time <= get_today_zero_time():
+            next_time = last_time + 300
+            flow = self.get_flow(zero_time, next_time)
+            print(get_time_str_by_ts(next_time), flow)
+            last_time += 300
+            time.sleep(0.5)
 
 
 s = S()