|
@@ -14,6 +14,7 @@ from applications import longArticlesMySQL, PQMySQL, WeixinSpider, Functions, lo
|
|
|
|
|
|
TASK_NAME = "updateMinigramInfoDaily"
|
|
|
|
|
|
+
|
|
|
def get_yesterday():
|
|
|
yesterday = datetime.today() - timedelta(1)
|
|
|
return yesterday
|
|
@@ -38,7 +39,7 @@ class DailyDataManager(object):
|
|
|
biz_date_ts = biz_date_midnight.timestamp()
|
|
|
biz_date_end_ts = biz_date_ts + 24 * 60 * 60 - 1
|
|
|
sql2 = f"""
|
|
|
- select ContentUrl, wx_sn, createTime
|
|
|
+ select ContentUrl, wx_sn, updateTime
|
|
|
from official_articles_v2
|
|
|
where createTime between {biz_date_ts} and {biz_date_end_ts};
|
|
|
-- and accountName in (
|
|
@@ -210,7 +211,8 @@ class DailyDataManager(object):
|
|
|
final[sub_key] = length
|
|
|
tt[key] = final
|
|
|
for key in first_level:
|
|
|
- temp = [len(first_level[key]), tt.get(key, {}).get(0, 0), tt.get(key, {}).get(1, 0), tt.get(key, {}).get(2, 0)]
|
|
|
+ temp = [len(first_level[key]), tt.get(key, {}).get(0, 0), tt.get(key, {}).get(1, 0),
|
|
|
+ tt.get(key, {}).get(2, 0)]
|
|
|
L[key] = temp
|
|
|
return L
|
|
|
|
|
@@ -332,6 +334,7 @@ def updateMinigramInfoJob(biz_date=None):
|
|
|
message="小程序更新失败---{}, 报错信息是: {}".format(biz_date.__str__(), e)
|
|
|
)
|
|
|
|
|
|
+
|
|
|
def main():
|
|
|
parser = ArgumentParser()
|
|
|
parser.add_argument("--run-date",
|
|
@@ -359,5 +362,6 @@ def main():
|
|
|
# message="更新文章小程序信息任务正常执行"
|
|
|
# )
|
|
|
|
|
|
+
|
|
|
if __name__ == '__main__':
|
|
|
main()
|