附件识别支持wps,ai提取优化医疗产品判断条件

BaseDataMaintenance/maintenance/dataflow.py

@@ -4919,7 +4919,7 @@ class Dataflow_dumplicate(Dataflow):
 
         if item:
             log("start dumplicate_comsumer_handle")
-            self.dumplicate_comsumer_handle(item,None,self.ots_client,get_all=False,upgrade=True)
+            self.dumplicate_comsumer_handle(item,None,self.ots_client,get_all=True,upgrade=False)
             return
 
     def test_merge(self,list_docid_less,list_docid_greater):
@@ -5158,7 +5158,7 @@ if __name__ == '__main__':
     # test_attachment_interface()
     df_dump = Dataflow_dumplicate(start_delete_listener=False)
     # df_dump.start_flow_dumplicate()
-    df_dump.test_dumplicate(614326449
+    df_dump.test_dumplicate(626076001
                             )
     # 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()

BaseDataMaintenance/maintenance/dataflow_mq.py

@@ -446,6 +446,8 @@ class Dataflow_ActivteMQ_attachment(Dataflow_attachment):
                 #调用接口处理结果
                 start_time = time.time()
                 _filetype = attach.getProperties().get(attachment_filetype)
+                if str(_filetype)=="wps":
+                    _filetype = "doc"
 
                 # _data_base64 = base64.b64encode(open(localpath,"rb").read())
                 # _success,_html,swf_images = getAttachDealInterface(_data_base64,_filetype)