|
@@ -1534,6 +1534,11 @@ class Dataflow_ActivteMQ_extract(Dataflow_extract):
|
|
|
|
|
|
|
|
|
def merge_json(self,extract_json,extract_ai_json):
|
|
|
+
|
|
|
+ def get_ai_money(_text):
|
|
|
+ b = re.search(r'[\d,,\.]+[亿万元人民币]+',_text)
|
|
|
+ if b is not None:
|
|
|
+ return b.group()
|
|
|
_extract = {}
|
|
|
if extract_json is not None:
|
|
|
try:
|
|
@@ -1620,6 +1625,7 @@ class Dataflow_ActivteMQ_extract(Dataflow_extract):
|
|
|
|
|
|
if not has_budget or budget_unexpected:
|
|
|
_budget = _extract_ai.get("招标信息",{}).get("项目预算","")
|
|
|
+ _budget = get_ai_money(_budget)
|
|
|
if _budget is not None and _budget!="":
|
|
|
_budget = getUnifyMoney(_budget)
|
|
|
if _budget>0:
|
|
@@ -1647,7 +1653,8 @@ class Dataflow_ActivteMQ_extract(Dataflow_extract):
|
|
|
else:
|
|
|
_pack = "Project"
|
|
|
_win_money = _win_dict.get("中标金额")
|
|
|
- if _win_money!="":
|
|
|
+ _win_money = get_ai_money(_win_money)
|
|
|
+ if _win_money is not None and _win_money!="":
|
|
|
_win_money = getUnifyMoney(_win_money)
|
|
|
else:
|
|
|
_win_money = 0
|