行业分类使用"{}"

.idea/encodings.xml

@@ -1,11 +1,13 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <project version="4">
   <component name="Encoding">
+    <file url="file://$PROJECT_DIR$/BaseDataMaintenance/attachmentProcessTime.xlsx" charset="GBK" />
+    <file url="file://$PROJECT_DIR$/BaseDataMaintenance/attachmentProcessTime.xlsx" charset="GBK" />
     <file url="file://$PROJECT_DIR$/BaseDataMaintenance/dataSource/searchPaddle.py" charset="GBK" />
     <file url="file://$PROJECT_DIR$/BaseDataMaintenance/maintenance/attachment/2022-01-18_183521_export11.xlsx" charset="GBK" />
-    <file url="file://$PROJECT_DIR$/BaseDataMaintenance/maintenance/attachment/2022-01-18_183521_export11.xlsx" charset="GBK" />
-    <file url="file://$PROJECT_DIR$/BaseDataMaintenance/maintenance/attachment/2022-01-18_183521_export11.xlsx" charset="GBK" />
     <file url="file://$PROJECT_DIR$/BaseDataMaintenance/model/ots/2022-01-19_214304_export11.xlsx" charset="GBK" />
+    <file url="file://$PROJECT_DIR$/attachmentProcessTime2.xlsx" charset="GBK" />
+    <file url="file://$PROJECT_DIR$/attachmentProcessTime2.xlsx" charset="GBK" />
     <file url="file://$PROJECT_DIR$/common/Utils.py" charset="GBK" />
     <file url="file://$PROJECT_DIR$/common/multiThread.py" charset="GBK" />
     <file url="file://$PROJECT_DIR$/dataSource" charset="GBK" />

.idea/misc.xml

@@ -1,6 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <project version="4">
-  <component name="ProjectRootManager" version="2" languageLevel="JDK_13" default="false" project-jdk-name="Python 3.5 (dl_nlp)" project-jdk-type="Python SDK">
+  <component name="ProjectRootManager" version="2" languageLevel="JDK_13" default="false" project-jdk-name="Python 3.7 (py37)" project-jdk-type="Python SDK">
     <output url="file://$PROJECT_DIR$/out" />
   </component>
 </project>

BaseDataMaintenance/maintenance/dataflow_mq.py

@@ -626,9 +626,10 @@ class Dataflow_ActivteMQ_extract(Dataflow_extract):
             #     else:
             #         log("%s--%s"%(str(resp.status_code),resp.content.decode("utf8")))
             #         all_done = -3
-            _to_ack = False
-            if all_done>0 and len(_extract.getProperties().get(document_extract2_extract_json,""))<=2:
-                all_done = -4
+            # _to_ack = False
+            # if all_done>0 and len(_extract.getProperties().get(document_extract2_extract_json,""))<=2:
+            #     all_done = -4
+            _extract.setValue(document_extract2_industry_json,"{}",True)
             try:
                 if all_done!=1:
                     sentMsgToDD("要素提取失败：docid:%d with result:%d"%(item.get(document_tmp_docid),all_done))