|
@@ -1298,7 +1298,9 @@ class Dataflow_ActivteMQ_extract(Dataflow_extract):
|
|
|
docchannel = _extract.get("docchannel",{}).get("docchannel","")
|
|
|
doctype = _extract.get("docchannel",{}).get("doctype","")
|
|
|
entity_len = len(_extract.get("dict_enterprise",{}).keys())
|
|
|
- product = str(_extract.get("product",""))
|
|
|
+ products = str(_extract.get("product_attrs",""))
|
|
|
+ demand_info = str(_extract.get("demand_info",""))
|
|
|
+ project_name = str(_extract.get("name",""))
|
|
|
class_name = _extract.get("industry",{}).get("class_name","")
|
|
|
_entity = None
|
|
|
if entity_len>0:
|
|
@@ -1354,7 +1356,7 @@ class Dataflow_ActivteMQ_extract(Dataflow_extract):
|
|
|
return True,_reason
|
|
|
if not has_win_tenderer and docchannel in {"中标信息","候选人公示","合同公告","验收合同"}:
|
|
|
return True,_reason
|
|
|
- if class_name=="医疗设备" or self.MP.is_medical_product(product):
|
|
|
+ if class_name=="医疗设备" or self.MP.is_medical_product(products) or self.MP.is_medical_product(demand_info) or self.MP.is_medical_product(project_name):
|
|
|
_reason = "medical product"
|
|
|
return True,_reason
|
|
|
if budget_unexpected or winprice_unexpected:
|