新增上市企业信息、财务数据脚本维护

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

-"""
+"""
@@ -444,13 +444,13 @@ def getReportTime():
 
     #todo:正式任务
     # 获取当前日期和时间
-    current_date = datetime.now()
+    current_date_ = datetime.now()
     # 计算昨天的日期
     # yesterday = current_date - timedelta(days=1)
     # 格式化昨天的日期
     # report_date = yesterday.strftime('%Y-%m-%d')
     # list_date.append(report_date)
-    year = int(current_date.strftime('%Y'))
+    year = int(current_date_.strftime('%Y'))
     # list_date = ['2023-09-30','2023-06-30','2023-03-31']
 
     list_month = ['-12-31', '-09-30', '-06-30', '-03-31']
@@ -458,7 +458,7 @@ def getReportTime():
         for month in list_month:
             date = str(year) + month
             #todo:判断拼接的报告期是否大于当前日期，如果大于当前日期，怎说明还没到这个时间，跳过
-            current_date = current_date.strftime('%Y-%m-%d')
+            current_date = current_date_.strftime('%Y-%m-%d')
             if current_date < date:
                 continue
             list_date.append(date)
@@ -471,8 +471,8 @@ def job(taskType,cnx,cursor):
     while True:
 
         # 从redis中获取企业信用代码
-        social_code = baseCore.redicPullData('FinanceFromEast:finance_socialCode')
-        # social_code = '91420300178856869P'
+        # social_code = baseCore.redicPullData('FinanceFromEast:finance_socialCode')
+        social_code = '9135020070548149XE'
         # 判断 如果Redis中已经没有数据，则等待
         if social_code == None or social_code == 'None':
             log.info('======已没有数据==========等待=====')
@@ -562,6 +562,7 @@ def job(taskType,cnx,cursor):
         end_time = time.time()
         log.info(f'===={com_code}====该企业耗时{end_time - start_time}===')
         flag = 1
+        break
     cnx.close()
     cursor.close()
     baseCore.close()

comData/ipoInfo/ipoInfo_newadd.py

@@ -19,7 +19,7 @@ list_all_info = []
 # 需要提供股票代码、企业信用代码
 while True:
     # com_code1 = baseCore.redicPullData('Ipo_newsAdd:comCode')
-    com_code1 = '200725'
+    com_code1 = '837748'
     if com_code1:
         pass
     else:
@@ -98,6 +98,8 @@ while True:
             jys_code = '2'
         if "深圳" in jys:
             jys_code = '3'
+        if "北京" in jys:
+            jys_code = '1'
     except:
         jys = json_1['jbzl'][0]['SECURITY_TYPE']
         if "北京" in jys: