|
|
@@ -120,7 +120,7 @@ class UpdatePublishedArticlesMinigramDetail(object):
|
|
|
:return:
|
|
|
"""
|
|
|
select_sql = f"""
|
|
|
- SELECT first_uv, split0, split1, split2
|
|
|
+ SELECT first_uv, split0, split0_head, split0_recommend, split1, split1_head, split1_recommend, split2, split2_head, split2_recommend
|
|
|
FROM changwen_data_rootsourceid
|
|
|
WHERE root_source_id = '{root_source_id}' AND dt = '{dt}';
|
|
|
"""
|
|
|
@@ -263,7 +263,10 @@ class UpdatePublishedArticlesMinigramDetail(object):
|
|
|
# do update job
|
|
|
update_sql = f"""
|
|
|
UPDATE {DETAIL_TABLE}
|
|
|
- SET first_level = %s, fission_0 = %s, fission_1 = %s, fission_2 = %s
|
|
|
+ SET first_level = %s,
|
|
|
+ fission_0 = %s, fission_0_head = %s, fission_0_recommend = %s,
|
|
|
+ fission_1 = %s, fission_1_head = %s, fission_1_recommend = %s,
|
|
|
+ fission_2 = %s, fission_2_head = %s, fission_2_recommend = %s
|
|
|
WHERE root_source_id = %s and recall_dt = %s;
|
|
|
"""
|
|
|
self.piaoquan_crawler_db_client.save(
|
|
|
@@ -271,8 +274,14 @@ class UpdatePublishedArticlesMinigramDetail(object):
|
|
|
params=(
|
|
|
mini_program_detail['first_uv'],
|
|
|
mini_program_detail['split0'],
|
|
|
+ mini_program_detail['split0_head'],
|
|
|
+ mini_program_detail['split0_recommend'],
|
|
|
mini_program_detail['split1'],
|
|
|
+ mini_program_detail['split1_head'],
|
|
|
+ mini_program_detail['split1_recommend'],
|
|
|
mini_program_detail['split2'],
|
|
|
+ mini_program_detail['split2_head'],
|
|
|
+ mini_program_detail['split2_recommend'],
|
|
|
root_source_id,
|
|
|
recall_dt
|
|
|
)
|
