kaku/FzHUEL
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

updata:更新接口和表结构

Browse Source
This commit is contained in:
kaku
2024-07-05 23:20:12 +08:00
parent eff85c91db
commit 8b91e5a789
8 changed files with 159 additions and 173 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
db/fz_data.py
View File

@@ -19,9 +19,9 @@ def saveFzData(data) -> bool:
sql = """
INSERT INTO table_zhapian
VALUES (
%(uuid)s,%(callednm)s,%(zptype)s,%(zpfeatures)s,%(early_warning_time)s,
%(warninglevel)s,%(zpcallernm)s,%(talktime)s,%(auth_code)s,%(student_number)s,
%(transfer_amout)s,%(url_or_app_name)s,%(zp_account)s
%(uuid)s,%(callednm)s,%(isPushZkj)s,%(called_city_name)s,%(called_province_name)s,%(called_location_county)s,
%(insert_time)s,%(warninglevel)s,%(zpfeatures)s,%(url)s,%(data_source)s,%(url_or_app_name)s,
%(called_location_province)s,%(pushZkjTime)s,%(zp_ip_address)s,%(first_login_time)s,%(called_location_city)s
);
"""
conn = getConn()
@@ -29,21 +29,26 @@ def saveFzData(data) -> bool:
try:
for message in data:
message.setdefault("uuid",None)
message.setdefault("callednm",None)
message.setdefault("zptype",None)
message.setdefault("zpfeatures",None)
message.setdefault("early_warning_time",None)
message.setdefault("isPushZkj",None)
message.setdefault("called_city_name",None)
message.setdefault("called_province_name",None)
message.setdefault("called_location_county",None)
message.setdefault("insert_time",None)
message.setdefault("warninglevel",None)
message.setdefault("zpcallernm",None)
message.setdefault("talktime",None)
message.setdefault("auth_code",None)
message.setdefault("student_number",None)
message.setdefault("transfer_amout",None)
message.setdefault("zpfeatures",None)
message.setdefault("url",None)
message.setdefault("data_source",None)
message.setdefault("url_or_app_name",None)
message.setdefault("zp_account",None)
message.setdefault("called_location_province",None)
message.setdefault("pushZkjTime",None)
message.setdefault("zp_ip_address",None)
message.setdefault("first_login_time",None)
message.setdefault("called_location_city",None)
print("已保存",message.get("uuid"))
cursor.execute(sql,message)
conn.commit()
except:
except Exception as e:
print(e)
return False
conn.close()
return True
@@ -51,7 +56,7 @@ def saveFzData(data) -> bool:
def LoadFzData():
"从数据库读取数据"
sql = """
SELECT * FROM `table_zhapian` ORDER BY `early_warning_time` DESC LIMIT 0,1000;
SELECT * FROM `table_zhapian` ORDER BY `insert_time` DESC LIMIT 0,1000;
"""
conn = getConn()
cursor = conn.cursor()