AI提取优化%金额

BaseDataMaintenance/maintenance/dataflow.py

@@ -2355,6 +2355,7 @@ class Dataflow_dumplicate(Dataflow):
         approval_greater = document_greater.get("approval",[])
         source_type_greater = document_greater.get("source_type")
 
+
         hard_level=1
         if docchannel_less==docchannel_greater==302:
             hard_level=2
@@ -5117,14 +5118,14 @@ if __name__ == '__main__':
     # test_attachment_interface()
     df_dump = Dataflow_dumplicate(start_delete_listener=False)
     # df_dump.start_flow_dumplicate()
-    # df_dump.test_dumplicate(606243000
-    #                         )
+    df_dump.test_dumplicate(585953643
+                            )
     # df_dump.dumplicate_comsumer_handle_interface(603504420,document_table="document_0000",document_table_index="document_0000_index",project_table="project_0000",project_table_index="project_0000_index_formerge")
     # compare_dumplicate_check()
     # df_dump.test_merge([391898061
     #                     ],[371551361,])
     # df_dump.flow_remove_project_tmp()
-    fix_merge_docid(595271944)
+    # fix_merge_docid(595271944)
     print("takes",time.time()-a)
     # df_dump.fix_doc_which_not_in_project()
     # df_dump.delete_projects_by_document(16288036)

BaseDataMaintenance/maintenance/major_project/unionDocument.py

@@ -307,10 +307,13 @@ class MajorUnion():
 
 
     def producer(self):
+        _time = getCurrent_date(format="%Y-%m-%d %H:%M:%S")
+        end_time = timeAdd(_time,days=-7,format="%Y-%m-%d %H:%M:%S")
         bool_query = BoolQuery(must_queries=[
-            RangeQuery(major_project_status,1,50,True,True),
+            # RangeQuery(major_project_status,1,50,True,True),
             # RangeQuery(major_project_status,201,301,True,True),
             # TermQuery(major_project_id,"00048953975ad762e883f1626f6b99ec")
+            RangeQuery(major_project_update_time,range_to=end_time)
             ]
         )
 
@@ -367,6 +370,7 @@ class MajorUnion():
 
             #修改status
             self.set_status_to_adult(_major)
+            _major.setValue(major_project_update_time,getCurrent_date(format="%Y-%m-%d %H:%M:%S"),True)
             _major.update_row(self.ots_client)
             return