|
@@ -1,9 +1,22 @@
|
|
|
"""
|
|
|
@author: luojunhui
|
|
|
"""
|
|
|
+
|
|
|
from config import daily_video
|
|
|
|
|
|
|
|
|
+def convertDt(dt_str):
|
|
|
+ """
|
|
|
+ 切换字符串
|
|
|
+ :param dt_str:
|
|
|
+ :return:
|
|
|
+ """
|
|
|
+ year = dt_str[:4]
|
|
|
+ month = dt_str[4:6]
|
|
|
+ day = dt_str[6:]
|
|
|
+ return "{}-{}-{}".format(year, month, day)
|
|
|
+
|
|
|
+
|
|
|
async def insert(db_client, params, request_id):
|
|
|
"""
|
|
|
|
|
@@ -28,9 +41,9 @@ async def insert(db_client, params, request_id):
|
|
|
|
|
|
insert_sql = f"""
|
|
|
INSERT INTO {daily_video}
|
|
|
- (video_id, uid, title, return_cnt, view_cnt, share_cnt, category, ros, rov, dt)
|
|
|
+ (video_id, uid, title, return_cnt, view_cnt, share_cnt, category, ros, rov, dt, date_time)
|
|
|
values
|
|
|
- (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s);
|
|
|
+ (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s);
|
|
|
"""
|
|
|
try:
|
|
|
await db_client.asyncInsert(
|
|
@@ -45,7 +58,8 @@ async def insert(db_client, params, request_id):
|
|
|
category,
|
|
|
float(int(return_cnt) / int(view_cnt)) if int(view_cnt) > 0 else 0,
|
|
|
float(int(return_cnt) / int(share_cnt)) if int(share_cnt) > 0 else 0,
|
|
|
- dt
|
|
|
+ dt,
|
|
|
+ convertDt(dt)
|
|
|
)
|
|
|
)
|
|
|
response = {
|