修复数据遗漏的问题

BaseDataMaintenance/fixDoc_to_queue_extract.py

@@ -8,4 +8,19 @@ from BaseDataMaintenance.maintenance.dataflow_mq import fixDoc_to_queue_extract,
 
 if __name__ == '__main__':
     # fixDoc_to_queue_extract()
-    fixDoc_to_queue_init(filename="/data/python/flow_init_check/flow_init_2023-08-15.xlsx")
+    fixDoc_to_queue_init(filename="/data/python/flow_init_check/flow_init_2023-08-13.xlsx")
+    fixDoc_to_queue_init(filename="/data/python/flow_init_check/flow_init_2023-08-12.xlsx")
+    fixDoc_to_queue_init(filename="/data/python/flow_init_check/flow_init_2023-08-11.xlsx")
+    fixDoc_to_queue_init(filename="/data/python/flow_init_check/flow_init_2023-08-10.xlsx")
+    fixDoc_to_queue_init(filename="/data/python/flow_init_check/flow_init_2023-08-09.xlsx")
+    fixDoc_to_queue_init(filename="/data/python/flow_init_check/flow_init_2023-08-08.xlsx")
+    fixDoc_to_queue_init(filename="/data/python/flow_init_check/flow_init_2023-08-07.xlsx")
+    fixDoc_to_queue_init(filename="/data/python/flow_init_check/flow_init_2023-08-06.xlsx")
+    fixDoc_to_queue_init(filename="/data/python/flow_init_check/flow_init_2023-08-05.xlsx")
+    fixDoc_to_queue_init(filename="/data/python/flow_init_check/flow_init_2023-08-04.xlsx")
+    fixDoc_to_queue_init(filename="/data/python/flow_init_check/flow_init_2023-08-03.xlsx")
+    fixDoc_to_queue_init(filename="/data/python/flow_init_check/flow_init_2023-08-02.xlsx")
+    fixDoc_to_queue_init(filename="/data/python/flow_init_check/flow_init_2023-08-01.xlsx")
+    fixDoc_to_queue_init(filename="/data/python/flow_init_check/flow_init_2023-07-31.xlsx")
+    fixDoc_to_queue_init(filename="/data/python/flow_init_check/flow_init_2023-07-30.xlsx")
+    fixDoc_to_queue_init(filename="/data/python/flow_init_check/flow_init_2023-07-29.xlsx")

BaseDataMaintenance/maintenance/dataflow_mq.py

@@ -1510,7 +1510,8 @@ def fixDoc_to_queue_init(filename=""):
     if filename=="":
         filename = os.path.join(current_path,"check.xlsx")
     df = pd.read_excel(filename)
-    dict_oracle2ots.pop("docchannel")
+    if "docchannel" in dict_oracle2ots:
+        dict_oracle2ots.pop("docchannel")
     row_name = ",".join(list(dict_oracle2ots.keys()))
     conn = getConnection_oracle()
     cursor = conn.cursor()
@@ -1523,6 +1524,7 @@ def fixDoc_to_queue_init(filename=""):
             cursor.execute(sql)
             log("%d:%s"%(_count,sql))
     conn.commit()
+    conn.close()
 
 if __name__ == '__main__':
     # di = Dataflow_init()