diff --git a/bi/vas_day_flow.py b/bi/vas_day_flow.py
index a53bd18..23578c6 100644
--- a/bi/vas_day_flow.py
+++ b/bi/vas_day_flow.py
@@ -28,7 +28,7 @@ class S:
         if len(rows) > 0:
             flow = safe_get_int(rows[0], "flow")
 
-        sql_except = '''select sum(pay_amount) flow from vas_order where ct>={} and ct<{} and order_status in (1,2) product_id in ('outer_raven');'''.format(st, et)
+        sql_except = '''select sum(pay_amount) flow from vas_order where ct>={} and ct<{} and order_status in (1,2) and product_id in ('outer_raven');'''.format(st, et)
         rows_except = self.mysql_db_vas.query(sql_except)
         flow_except = 0
         if len(rows_except) > 0: