列表查询逻辑提交

comData/weixin_solo/wxList.py

@@ -92,7 +92,7 @@ def insertWxList(dic_url,json_search,page):
     for one_news in list_all_news:
         listCount=listCount+1
         news_title = one_news['title']
-        timestamp = one_news['create_time']
+        timestamp = one_news['update_time']
         time_local = time.localtime(timestamp)
         news_date = time.strftime("%Y-%m-%d %H:%M:%S", time_local)
         url_news = one_news['link']
@@ -201,10 +201,19 @@ def getPageData(dic_url,page):
         error = [origin, url_, info_source_code, str_t, '无效session']
         insertBadSql(error)
         return getPageData(dic_url, page)
+    elif ret == 200074:
+        #{"base_resp": {"ret": 200074, "err_msg": "default"}}
+        log.info(f'======{origin}-----{biz}----该账号未登录成功=======')
+        # session失效修改token
+        updateTokeen(token, 2)
+        error = [origin, url_, info_source_code, str_t, '该账号未登录成功']
+        insertBadSql(error)
+        return getPageData(dic_url, page)
     else:
         log.info(f'======{origin}-----{biz}----该账号其他错误=======')
         error = [origin, url_, info_source_code, str_t, '其他错误']
         insertBadSql(error)
+        updateTokeen(token, 2)
         return True
     # 修改token使用时间
     updateTokeen(token, 3)
@@ -225,7 +234,7 @@ def getWxList(infoSourceCode):
         return
     origin = dic_url['name']
     biz = dic_url['biz']
-    for page in range(1,2):
+    for page in range(1,6):
         retFlag = getPageData(dic_url, page)
         time.sleep(random.randint(60,181))
         if retFlag: