|
|
@@ -291,9 +291,11 @@ class CooperateAccountsMonitorTask(CooperateAccountsMonitorMapper):
|
|
|
params.append(single_param)
|
|
|
|
|
|
query = """
|
|
|
- INSERT IGNORE INTO cooperate_accounts_daily_detail
|
|
|
+ INSERT INTO cooperate_accounts_daily_detail
|
|
|
(gh_id, account_name, app_msg_id, publish_type, position, article_title, article_link, article_cover, article_desc, publish_timestamp, wx_sn, read_cnt, like_cnt)
|
|
|
- VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s);
|
|
|
+ VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s)
|
|
|
+ ON DUPLICATE KEY UPDATE
|
|
|
+ read_cnt = VALUES(read_cnt), like_cnt = VALUES(like_cnt);
|
|
|
"""
|
|
|
await self.pool.async_save(query=query, params=params, batch=True)
|
|
|
|
luojunhui