公众号账号名称

applications/pipeline.py

@@ -76,14 +76,15 @@ class LongArticlesPipeline(object):
         return response.json()['is_bad']
 
     @classmethod
-    def deal(cls, article_obj):
+    def deal(cls, article_obj, account_name):
         """
+        :param account_name:
         :param article_obj:
         :return:
         """
         article_bad_flag = cls.article_bad(
             title=article_obj['title'],
-            account_nickname=article_obj['crawlerAccountName']
+            account_nickname=account_name
         )
         if article_bad_flag:
             response = {
@@ -94,7 +95,7 @@ class LongArticlesPipeline(object):
         else:
             history_exists_flag = cls.history_exists(
                 title=article_obj['title'],
-                account_nickname=article_obj['crawlerAccountName'],
+                account_nickname=account_name,
                 plan_name=article_obj['producePlanName']
             )
             if history_exists_flag:

routes/AccountArticleRank.py

@@ -63,7 +63,7 @@ class AccountArticleRank(object):
         self.publishArticleList = []
         self.filter_list = []
         for item in self.params['publishArticleList']:
-            flag = self.pipeline.deal(item)
+            flag = self.pipeline.deal(item, self.accountName)
             if flag:
                 item['filterReason'] = flag['filterReason']
                 self.filter_list.append(item)