雅虎企业动态

base/RedisPPData.py

@@ -72,7 +72,7 @@ def NewsEnterprise_task():
 #企业公告
 def NoticeEnterprise():
     # 获取国内企业
-    gn_query = "select SocialCode from EnterpriseInfo where Place = '1' and SecuritiesCode is not null limit 1 "
+    gn_query = "select SocialCode from EnterpriseInfo where Place = '1' and SecuritiesCode is not null limit 10 "
     cursor.execute(gn_query)
     gn_result = cursor.fetchall()
     gn_social_list = [item[0] for item in gn_result]
@@ -95,13 +95,14 @@ def NoticeEnterprise_task():
 #企业年报
 def AnnualEnterprise():
     # 获取国内企业
-    gn_query = "select SocialCode from EnterpriseInfo where Place = '1' and SecuritiesCode is not null"
+    gn_query = "select SocialCode from EnterpriseInfo where Place = '1' and SecuritiesCode is not null limit 10"
     cursor.execute(gn_query)
     gn_result = cursor.fetchall()
     gn_social_list = [item[0] for item in gn_result]
     print('=======')
     for item in gn_social_list:
         r.rpush('AnnualEnterprise:gnqy_socialCode', item)
+
 #企业年报定时任务
 def AnnualEnterprise_task():
     # 实例化一个调度器
@@ -162,6 +163,27 @@ def weixin_task():
         print('定时采集异常', e)
         pass
 
+# 企业年报——雪球网
+def AnnualEnterpriseIPO():
+    # 获取国内上市企业
+    gn_query = "select SocialCode from EnterpriseInfo where Place = '1' and SecuritiesCode is not null and isIPO = 1 limit 10"
+    cursor.execute(gn_query)
+    gn_result = cursor.fetchall()
+    gn_social_list = [item[0] for item in gn_result]
+    print('=======')
+    for item in gn_social_list:
+        r.rpush('AnnualEnterprise:gnshqy_socialCode', item)
+#国外企业基本信息
+def BaseInfoEnterpriseAbroad():
+    # 获取国外企业
+    gn_query = "select id from EnterpriseInfo where Place = '2' limit 10 "
+    cursor.execute(gn_query)
+    gn_result = cursor.fetchall()
+    gn_social_list = [item[0] for item in gn_result]
+    print('=======')
+    for item in gn_social_list:
+        r.rpush('BaseInfoEnterprise:gwqy_socialCode', item)
+
 ##福布斯=====从数据库中读取信息放入redis
 def FBS():
     # todo:调整为获取福布斯的数据库
@@ -185,8 +207,15 @@ def FBS():
             r.rpush('NewsEnterpriseFbs:gnqy_socialCode', item)
 
 
+
+
+
 if __name__ == "__main__":
     start = time.time()
+    # NoticeEnterprise()
+    # AnnualEnterpriseIPO()
+    # AnnualEnterprise()
+    # BaseInfoEnterpriseAbroad()
     # NewsEnterprise_task()
     # NewsEnterprise()
     # BaseInfoEnterprise()