东方财富网财务数据

comData/caiwushuju/东方财富网财务数据.py

-"""
+"""
@@ -27,7 +27,7 @@ def check_code(com_code):
 
 def check_date(com_code,info_date):
     r = redis.Redis(host="114.115.236.206", port=6379, password='clbzzsn', db=3)
-    res = r.sismember('com_caiwushuju_date::'+com_code, info_date)  # 注意是 保存set的方式
+    res = r.sismember('com_caiwushuju_code::'+com_code, info_date)  # 注意是 保存set的方式
     if res:
         return True
     else:
@@ -437,15 +437,16 @@ def getReportTime():
     # timeNow = baseCore.getNowTime(1)[:10]
     list_date = []
     # 2023-04-01
+    #todo:正式任务
     # 获取当前日期和时间
-    current_date = datetime.now()
+    # current_date = datetime.now()
     # 计算昨天的日期
-    yesterday = current_date - timedelta(days=1)
+    # yesterday = current_date - timedelta(days=1)
     # 格式化昨天的日期
-    report_date = yesterday.strftime('%Y-%m-%d')
-    list_date.append(report_date)
-    year = int(current_date.strftime('%Y'))
-    # list_date = ['2023-03-31']
+    # report_date = yesterday.strftime('%Y-%m-%d')
+    # list_date.append(report_date)
+    # year = int(current_date.strftime('%Y'))
+    list_date = ['2023-03-31']
 
     list_month = ['-12-31', '-09-30', '-06-30', '-03-31']
     for year in range(2022, 2018, -1):
@@ -459,7 +460,8 @@ def job(taskType):
     # 需要提供股票代码、企业信用代码
     while True:
         #从redis中获取企业信用代码
-        social_code = baseCore.redicPullData('FinanceFromEast:finance_socialCode')
+        social_code = baseCore.redicPullData('FinanceFromEast:eastfinance_socialCode')
+        # social_code = '91100000100003962T'
         # 判断 如果Redis中已经没有数据，则等待
         if social_code == None:
             time.sleep(20)
@@ -468,8 +470,12 @@ def job(taskType):
         sql_sel = f'''select securities_code,exchange from sys_base_enterprise_ipo where category = '1' and social_credit_code='{social_code}' '''
         cursor.execute(sql_sel)
         row = cursor.fetchone()
-
-        securities_code = row[0]
+        try:
+            securities_code = row[0]
+            pass
+        except:
+            log.info(f'======{social_code}没有股票代码======')
+            continue
         exchange = row[1]
         # for code in list_code:
         #     social_code = rows[0]
@@ -510,18 +516,17 @@ def job(taskType):
                         time.sleep(1)
                 print(res_baocun.text)
 
+                for nnn in range(0, 3):
+                    try:
+                        add_date(com_code, date_list)
+                        break
+                    except:
+                        time.sleep(1)
             if len(info_date_list) != 0:
                 for date in info_date_list:
                     date_list.append(date)
         print(date_list)
-        date_list = str(date_list)
-
-        for nnn in range(0, 3):
-            try:
-                add_date(com_code,date_list)
-                break
-            except:
-                time.sleep(1)
+        # date_list = str(date_list)
         end_time = time.time()
         log.info(f'===={com_code}====该企业耗时{end_time-start_time}===')
     cnx.close()
@@ -529,7 +534,7 @@ def job(taskType):
     baseCore.close()
 
 if __name__=='__main__':
-    task_type = '财务数据/东方财富网'
+    task_type = '财务数据/东方财富网/福布斯'
     job(task_type)