AI提取增加医疗产品数据

BaseDataMaintenance/maintenance/dataflow_mq.py

@@ -861,7 +861,7 @@ class Dataflow_ActivteMQ_extract(Dataflow_extract):
 
 
 
-    def start_extract_AI_listener(self,_count=6):
+    def start_extract_AI_listener(self,_count=8):
 
         self.list_extract_ai_comsumer = []
 
@@ -1691,6 +1691,8 @@ class Dataflow_ActivteMQ_extract(Dataflow_extract):
                 total_price = list_new_product[product_i].get("总价","")
                 pinmu_no = list_new_product[product_i].get("品目编号","")
                 pinmu_name = list_new_product[product_i].get("品目名称","")
+                if product=="":
+                    continue
                 product_attrs_new["data"].append({
                     "brand": str(brand),
                     "product": product,