定时删除attachment表数据修复

BaseDataMaintenance/maintenance/dataflow.py

@@ -4139,7 +4139,7 @@ if __name__ == '__main__':
     df_dump = Dataflow_dumplicate(start_delete_listener=False)
     # df_dump.start_flow_dumplicate()
     a = time.time()
-    df_dump.test_dumplicate(327798326)
+    df_dump.test_dumplicate(328386698)
     # df_dump.test_merge([292315564],[287890754])
     # df_dump.flow_remove_project_tmp()
     print("takes",time.time()-a)

BaseDataMaintenance/maintenance/dataflow_mq.py

@@ -518,7 +518,7 @@ class Dataflow_ActivteMQ_attachment(Dataflow_attachment):
         conn = getConnection_postgres()
         cursor = conn.cursor()
         cursor.execute(sql)
-        self.conn_attach.commit()
+        conn.commit()
         conn.close()
 
 
@@ -1517,4 +1517,8 @@ if __name__ == '__main__':
     # de.start_flow_extract()
     # fixDoc_to_queue_extract()
     # check_data_synchronization()
-    fixDoc_to_queue_init(filename="C:\\Users\\Administrator\\Desktop\\flow_init_2023-02-07.xlsx")
+    # fixDoc_to_queue_init(filename="C:\\Users\\Administrator\\Desktop\\flow_init_2023-02-07.xlsx")
+    current_date = getCurrent_date(format="%Y-%m-%d")
+    last_date = timeAdd(current_date,-30,format="%Y-%m-%d")
+    sql = " delete from attachment where crtime<='%s 00:00:00' "%(last_date)
+    print(sql)