fix
This commit is contained in:
parent
36ee501e3b
commit
557964ca6d
|
@ -46,8 +46,8 @@ class S:
|
|||
sql_q = "select * from vas_day_flow where pdate='{}'".format(get_time_str_by_ts(t))
|
||||
rows = self.mysql_db_bi.query(sql_q)
|
||||
if len(rows) > 0:
|
||||
sql_u = "update set vas_day_flow set flow=%s where pdate='{}'".format(get_time_str_by_ts(t))
|
||||
return self.mysql_db_bi.exec(sql_u, flow)
|
||||
sql_u = "update set vas_day_flow set flow=%s where pdate=%s"
|
||||
return self.mysql_db_bi.exec(sql_u, (flow, formatted_dt))
|
||||
else:
|
||||
sql_i = "insert into vas_day_flow (pdate, flow) values (%s,%s)"
|
||||
return self.mysql_db_bi.exec(sql_i, (formatted_dt, flow))
|
||||
|
|
Loading…
Reference in New Issue