证监会公告数据维护

comData/noticeReport_ZJH/证监会-公告.py

-"""
+"""
@@ -23,6 +23,8 @@ log = baseCore.getLogger()
 cnx = baseCore.cnx
 cursor = baseCore.cursor
 
+cnx_ = baseCore.cnx_
+cursor_ = baseCore.cursor_
 # tracker_conf = get_tracker_conf('./client.conf')
 # client = Fdfs_client(tracker_conf)
 
@@ -31,8 +33,8 @@ taskType = '企业公告/证监会'
 
 def secrchATT(item_id, name, type_id):
     sel_sql = '''select id from clb_sys_attachment where item_id = %s and name = %s and type_id=%s '''
-    cursor.execute(sel_sql, (item_id, name, type_id))
-    selects = cnx.fetchone()
+    cursor_.execute(sel_sql, (item_id, name, type_id))
+    selects = cnx_.fetchone()
     return selects
 
 
@@ -64,8 +66,8 @@ def tableUpdate(retData, com_name, year, pdf_name, num):
             status, create_by,
             create_time, page_size)
 
-        cursor.execute(Upsql, values)  # 插入
-        cnx.commit()  # 提交
+        cursor_.execute(Upsql, values)  # 插入
+        cnx_.commit()  # 提交
         log.info("更新完成:{}".format(Upsql))
         selects = secrchATT(item_id, pdf_name, type_id)
         id = selects[0]