证监会年报维护

comData/annualReport/证监会-年报.py

-import json
+import json
@@ -46,7 +46,7 @@ def RequestUrl(url, payload, item_id, start_time):
 def tableUpdate(year, name_pdf, type_id, item_id, group_name, path, full_path, category, file_size, order_by, status,
                 create_by, create_time, page_size):
 
-    sel_sql = '''select item_id from clb_sys_attachment where item_id = %s and year = %s'''
+    sel_sql = '''select item_id from clb_sys_attachment where item_id = %s and year = %s and type_id=1'''
     cursor_.execute(sel_sql, (item_id, year))
     selects = cursor_.fetchone()
     if selects:
@@ -117,7 +117,7 @@ def SpiderByZJH(url, payload, dic_info, num, start_time):
 
                 # page_size = 0
 
-                sel_sql = '''select item_id,year from clb_sys_attachment where item_id = %s and year = %s'''
+                sel_sql = '''select item_id,year from clb_sys_attachment where item_id = %s and year = %s and type_id=1'''
                 cursor_.execute(sel_sql, (item_id, year))
                 selects = cursor_.fetchone()
                 if selects:
@@ -322,7 +322,7 @@ if __name__ == '__main__':
         dic_parms = getUrl(code, url_parms, Catagory2_parms)
         SpiderByZJH(dic_parms["url"], dic_parms["payload"], dic_info, num, start_time)
         end_time = time.time()
-        print(f'{dic_info["short_name"]} ---- 该企业耗时 ---- {end_time - start_time}')
+        print(f'{dic_info[4]} ---- 该企业耗时 ---- {end_time - start_time}')
         count += 1
         runType = 'AnnualReportCount'
         baseCore.updateRun(social_code, runType, count)