|
@ -49,7 +49,7 @@ class DbTransfer(object): |
|
|
query_sub_in = '%s' % id |
|
|
query_sub_in = '%s' % id |
|
|
|
|
|
|
|
|
if query_sub_when == '': |
|
|
if query_sub_when == '': |
|
|
return |
|
|
return update_transfer |
|
|
query_sql = query_head + ' SET u = CASE port' + query_sub_when + \ |
|
|
query_sql = query_head + ' SET u = CASE port' + query_sub_when + \ |
|
|
' END, d = CASE port' + query_sub_when2 + \ |
|
|
' END, d = CASE port' + query_sub_when2 + \ |
|
|
' END, t = ' + str(int(last_time)) + \ |
|
|
' END, t = ' + str(int(last_time)) + \ |
|
@ -61,6 +61,7 @@ class DbTransfer(object): |
|
|
cur.close() |
|
|
cur.close() |
|
|
conn.commit() |
|
|
conn.commit() |
|
|
conn.close() |
|
|
conn.close() |
|
|
|
|
|
return update_transfer |
|
|
|
|
|
|
|
|
def push_db_all_user(self): |
|
|
def push_db_all_user(self): |
|
|
#更新用户流量到数据库 |
|
|
#更新用户流量到数据库 |
|
|