|
|
@@ -22,7 +22,7 @@ sys.path.append(os.getcwd())
|
|
|
from application.functions import get_redirect_url
|
|
|
from application.pipeline import PiaoQuanPipelineTest
|
|
|
from application.common.log import AliyunLogger, Local
|
|
|
-from application.common import MysqlHelper
|
|
|
+from application.common import MysqlHelper, Feishu
|
|
|
|
|
|
|
|
|
class ZFHYBFRecommend(object):
|
|
|
@@ -296,6 +296,19 @@ class ZFHYBFRecommend(object):
|
|
|
video_dict["crawler_rule"] = json.dumps(self.rule_dict)
|
|
|
video_dict["user_id"] = self.our_uid
|
|
|
video_dict["publish_time"] = video_dict["publish_time_str"]
|
|
|
+ values = [[
|
|
|
+ video_dict["video_id"],
|
|
|
+ time.strftime(
|
|
|
+ "%Y-%m-%d %H:%M:%S", time.localtime(int(time.time()))
|
|
|
+ ),
|
|
|
+ video_title,
|
|
|
+ cover_url,
|
|
|
+ video_url,
|
|
|
+ play_cnt
|
|
|
+ ]]
|
|
|
+ Feishu.insert_columns('xiaoniangao', 'xiaoniangao', "FPJe7M", "ROWS", 1, 2)
|
|
|
+ time.sleep(0.5)
|
|
|
+ Feishu.update_values('xiaoniangao', 'xiaoniangao', "FPJe7M", "A2:Z2", values)
|
|
|
self.download_cnt += 1
|
|
|
self.mq.send_msg(video_dict)
|
|
|
self.aliyun_log.logging(
|
