Skip to content

Z
zhichan
Commit dd60b4c8 by 黄静
Options

hj

parent b120ec7f
Showing with 184 additions and 188 deletions
entprofile/service/select_es_result.py
...@@ -30,192 +30,205 @@ class HX: ...@@ -30,192 +30,205 @@ class HX:
# self.es = Elasticsearch([self.esip], port=self.esport) # self.es = Elasticsearch([self.esip], port=self.esport)
def hxsearch(self,re_item): def hxsearch(self,re_item):
querybody = { if re_item == []:
"query": { querybody = {
"bool": { "query": {
"must": [ "bool": {
] "must": [
} {
}, "match_all": {}
"size": 2000, }
} ]
}
if "qiyeguimo" in re_item: },
dsl = { "size": 2000
"terms": {
"qiyeguimo.raw": re_item['qiyeguimo']
}
} }
querybody["query"]["bool"]["must"].append(dsl) else:
# print(querybody, 111) querybody = {
"query": {
if 'qiyeleixing' in re_item: "bool": {
dsl = { "must": [
"terms": { ]
"qiyeleixing.raw": re_item['qiyeleixing'] }
}} },
querybody['query']['bool']['must'].append(dsl) "size": 2000,
if 'chenglinianxian' in re_item:
years_value = re_item['chenglinianxian']
re_years_value_list = []
for years in years_value:
if years[0:4] in ['青年公司', '长青公司', '成熟公司', '长寿公司']:
re_years_value = years[0:4]
else:
re_years_value = years[0:3]
re_years_value_list.append(re_years_value)
# print(re_years_value_list, 111)
dsl = {
"terms": {
"chenglinianxian.raw": re_years_value_list
}
} }
querybody['query']['bool']['must'].append(dsl) if "qiyeguimo" in re_item:
dsl = {
"terms": {
if 'jingyingzhuangtai' in re_item: "qiyeguimo.raw": re_item['qiyeguimo']
dsl = { }
"terms": {
"jingyingzhuangtai.row": re_item['jingyingzhuangtai']
} }
} querybody["query"]["bool"]["must"].append(dsl)
querybody['query']['bool']['must'].append(dsl) # print(querybody, 111)
if 'jingyingdiqu' in re_item: if 'qiyeleixing' in re_item:
dsl = { dsl = {
"terms": { "terms": {
"jingyingdiqu.raw": re_item['jingyingdiqu'] "qiyeleixing.raw": re_item['qiyeleixing']
} }}
} querybody['query']['bool']['must'].append(dsl)
querybody['query']['bool']['must'].append(dsl)
if 'fengongsishuliang' in re_item:
branches = re_item['fengongsishuliang']
re_branches_list = []
for branch_item in branches:
if branch_item[0:4] in ['枝繁叶茂', '草木稀疏', '一枝独秀']:
re_branches = branch_item[0:4]
else:
re_branches = branch_item
re_branches_list.append(re_branches)
dsl = {
"terms": {
"fengongsishuliang.raw": re_branches_list
}
}
querybody['query']['bool']['must'].append(dsl)
if 'zhengzhao' in re_item: if 'chenglinianxian' in re_item:
dsl = { years_value = re_item['chenglinianxian']
"terms": { re_years_value_list = []
"zhengzhao.raw": re_item['zhengzhao'] for years in years_value:
if years[0:4] in ['青年公司', '长青公司', '成熟公司', '长寿公司']:
re_years_value = years[0:4]
else:
re_years_value = years[0:3]
re_years_value_list.append(re_years_value)
# print(re_years_value_list, 111)
dsl = {
"terms": {
"chenglinianxian.raw": re_years_value_list
}
} }
} querybody['query']['bool']['must'].append(dsl)
querybody['query']['bool']['must'].append(dsl)
if 'zhuanli' in re_item: if 'jingyingzhuangtai' in re_item:
patent_nu = re_item['zhuanli']
for zhuanli_item in patent_nu:
if zhuanli_item[0:2] == '专利':
re_patent_nu = zhuanli_item[0:4]
else:
re_patent_nu = zhuanli_item[0:4]
dsl = { dsl = {
"wildcard": { "terms": {
'zhuanli.raw': "*" + re_patent_nu + "*" "jingyingzhuangtai.row": re_item['jingyingzhuangtai']
} }
} }
querybody['query']['bool']['must'].append(dsl) querybody['query']['bool']['must'].append(dsl)
if 'shangbiao' in re_item: if 'jingyingdiqu' in re_item:
trademark = re_item['shangbiao']
for trademark_item in trademark:
if trademark_item[0:2] == '商标':
re_trademark = trademark_item[0:2]
else:
re_trademark = trademark_item[0:2]
dsl = { dsl = {
"wildcard": { "terms": {
"shangbiao.raw": "*" + re_trademark + "*" "jingyingdiqu.raw": re_item['jingyingdiqu']
} }
} }
querybody['query']['bool']['must'].append(dsl) querybody['query']['bool']['must'].append(dsl)
if 'zuopinzhuzuoquan' in re_item: if 'fengongsishuliang' in re_item:
work_nu = re_item['zuopinzhuzuoquan'] branches = re_item['fengongsishuliang']
for work_item in work_nu: re_branches_list = []
if work_item[0:4] == '作品著作': for branch_item in branches:
re_work_nu = work_item[0:4] if branch_item[0:4] in ['枝繁叶茂', '草木稀疏', '一枝独秀']:
else: re_branches = branch_item[0:4]
re_work_nu = work_item[0:4] else:
re_branches = branch_item
re_branches_list.append(re_branches)
dsl = { dsl = {
"wildcard": { "terms": {
"zuopinzhuzuoquan.raw": "*" + re_work_nu + "*" "fengongsishuliang.raw": re_branches_list
} }
} }
querybody['query']['bool']['must'].append(dsl) querybody['query']['bool']['must'].append(dsl)
if 'suozaidiqu' in re_item: if 'zhengzhao' in re_item:
address_nu = re_item['suozaidiqu']
for address_item in address_nu:
dsl = { dsl = {
"wildcard": { "terms": {
"suozaidiqu.raw": "*" + address_item + "*" "zhengzhao.raw": re_item['zhengzhao']
} }
} }
querybody['query']['bool']['must'].append(dsl) querybody['query']['bool']['must'].append(dsl)
if 'ruanjianzhuzuoquan' in re_item: if 'zhuanli' in re_item:
soft_nu = re_item['ruanjianzhuzuoquan'] patent_nu = re_item['zhuanli']
for soft_item in soft_nu: for zhuanli_item in patent_nu:
soft_label = soft_item[0:4] if zhuanli_item[0:2] == '专利':
re_patent_nu = zhuanli_item[0:4]
else:
re_patent_nu = zhuanli_item[0:4]
dsl = {
"wildcard": {
'zhuanli.raw': "*" + re_patent_nu + "*"
}
}
querybody['query']['bool']['must'].append(dsl)
if 'shangbiao' in re_item:
trademark = re_item['shangbiao']
for trademark_item in trademark:
if trademark_item[0:2] == '商标':
re_trademark = trademark_item[0:2]
else:
re_trademark = trademark_item[0:2]
dsl = {
"wildcard": {
"shangbiao.raw": "*" + re_trademark + "*"
}
}
querybody['query']['bool']['must'].append(dsl)
if 'zuopinzhuzuoquan' in re_item:
work_nu = re_item['zuopinzhuzuoquan']
for work_item in work_nu:
if work_item[0:4] == '作品著作':
re_work_nu = work_item[0:4]
else:
re_work_nu = work_item[0:4]
dsl = {
"wildcard": {
"zuopinzhuzuoquan.raw": "*" + re_work_nu + "*"
}
}
querybody['query']['bool']['must'].append(dsl)
if 'suozaidiqu' in re_item:
address_nu = re_item['suozaidiqu']
for address_item in address_nu:
dsl = {
"wildcard": {
"suozaidiqu.raw": "*" + address_item + "*"
}
}
querybody['query']['bool']['must'].append(dsl)
if 'ruanjianzhuzuoquan' in re_item:
soft_nu = re_item['ruanjianzhuzuoquan']
for soft_item in soft_nu:
soft_label = soft_item[0:4]
dsl = {
"wildcard": {
"ruanjianzhuzuoquan.raw": "*" + soft_label + "*"
}
}
querybody['query']['bool']['must'].append(dsl)
if 'zhengzhao' in re_item:
cliense_nu = re_item['zhengzhao']
dsl = { dsl = {
"wildcard": { "terms": {
"ruanjianzhuzuoquan.raw": "*" + soft_label + "*" "zhengzhao.raw": cliense_nu
} }
} }
querybody['query']['bool']['must'].append(dsl) querybody['query']['bool']['must'].append(dsl)
if 'zhengzhao' in re_item:
cliense_nu = re_item['zhengzhao']
dsl = {
"terms": {
"zhengzhao.raw": cliense_nu
}
}
querybody['query']['bool']['must'].append(dsl)
if 'chanpinxinxi' in re_item: if 'chanpinxinxi' in re_item:
product_info = re_item['chanpinxinxi'] product_info = re_item['chanpinxinxi']
dsl = { dsl = {
"terms": { "terms": {
"product_label.raw": product_info "product_label.raw": product_info
}
} }
} querybody['query']['bool']['must'].append(dsl)
querybody['query']['bool']['must'].append(dsl)
if 'chanpindalei' in re_item: if 'chanpindalei' in re_item:
product_cateory = re_item['chanpindalei'] product_cateory = re_item['chanpindalei']
dsl = { dsl = {
"terms": { "terms": {
"chanpindalei.keyword": product_cateory "chanpindalei.keyword": product_cateory
}
} }
} querybody['query']['bool']['must'].append(dsl)
querybody['query']['bool']['must'].append(dsl)
if 'fengxian' in re_item: if 'fengxian' in re_item:
fengxian_label = re_item['fengxian'] fengxian_label = re_item['fengxian']
dsl = { dsl = {
"terms": { "terms": {
"risk_label.keyword": fengxian_label "risk_label.keyword": fengxian_label
}
} }
} querybody['query']['bool']['must'].append(dsl)
querybody['query']['bool']['must'].append(dsl)
print('查询语法：', querybody) print('查询语法：', querybody)
searched = self.es.search(index=self.index_name, doc_type=self.index_type, body=querybody, request_timeout=1000) searched = self.es.search(index=self.index_name, doc_type=self.index_type, body=querybody, request_timeout=1000)
...@@ -270,47 +283,30 @@ def hx_company_list(server): ...@@ -270,47 +283,30 @@ def hx_company_list(server):
def hx_select_main(): def hx_select_main():
if request.method == 'POST': if request.method == 'POST':
requestdata = request.json requestdata = request.json
print(requestdata, 1121212) try:
base_result = ""
re_item = {}
# try:
for item in requestdata:
name = item['name']
list = item['list']
re_item[name] = list
company_hx_list = hx.hxsearch(re_item)
base_result_list = [] base_result_list = []
for company_name in company_hx_list: print(requestdata, 1121212)
base_result = companybase.companyinfo(company_name) re_item = {}
logo_url = hx.select_url(company_name) if requestdata != []:
base_result['logo'] = logo_url for item in requestdata:
base_result_list.append(base_result) name = item['name']
print("len_result",len(base_result_list)) list = item['list']
# except: re_item[name] = list
# base_result = [{ company_hx_list = hx.hxsearch(re_item)
# "company_name": "北京晟软在线科技有限公司", for company_name in company_hx_list:
# "business_scope": "技术开发、技术转让、技术咨询、技术服务;计算机系统服务;应用软件服务;软件开发。(企业依法自主选择经营项目,开展经营活动;依法须经批准的项目,经相关部门批准后依批准的内容开展经营活动;不得从事本市产业政策禁止和限制类项目的经营活动。)", base_result = companybase.companyinfo(company_name)
# "reg_unit": "100.000", logo_url = hx.select_url(company_name)
# "establish_time": "2010-11-03", base_result['logo'] = logo_url
# "legal_person_name": "赵学军", base_result_list.append(base_result)
# "reg_location": "北京市海淀区中关村软件园11号楼3层330", print("len_result",len(base_result_list))
# "logo": "https://gsb-zc.oss-cn-beijing.aliyuncs.com/北京晟软在线科技有限公司.png" else:
# }, { company_hx_list = hx.hxsearch(requestdata)
# "company_name": "北京游逗科技有限公司", for company_name in company_hx_list:
# "business_scope": "技术推广服务;票务代理(不含航空机票销售代理);旅游信息咨询(不含中介服务);酒店管理;风景名胜区规划;企业形象策划;企业管理咨询(不含中介服务);应用软件服务(不含医用软件服务);销售计算机、软件及辅助设备、电子产品、通讯设备;计算机系统服务。(企业依法自主选择经营项目,开展经营活动;依法须经批准的项目,经相关部门批准后依批准的内容开展经营活动;不得从事本市产业政策禁止和限制类项目的经营活动。)", base_result = companybase.companyinfo(company_name)
# "reg_unit": "200.000", logo_url = hx.select_url(company_name)
# "establish_time": "2017-11-27", base_result['logo'] = logo_url
# "legal_person_name": "王京", base_result_list.append(base_result)
# "reg_location": "北京市丰台区程庄北里13号楼二层207室", print("len_result", len(base_result_list))
# "logo": "暂无logo" except:
# }, { base_result_list = "暂无该检索信息，请您修改条件进行检索！"
# "company_name": "北京码农村科技有限公司",
# "business_scope": "技术开发、技术转让、技术咨询、技术推广、技术服务;计算机系统服务;软件开发;电脑动画设计;经济贸易咨询;企业策划;企业管理咨询;销售自行开发后的产品。(企业依法自主选择经营项目,开展经营活动;依法须经批准的项目,经相关部门批准后依批准的内容开展经营活动;不得从事本市产业政策禁止和限制类项目的经营活动。)",
# "reg_unit": "100.000",
# "establish_time": "2016-07-06",
# "legal_person_name": "白冰",
# "reg_location": "北京市海淀区高里掌路1号院6号楼104-165",
# "logo": "暂无logo"
# }]
print(base_result_list, 111)
return {"status": 200, "msg": "成功", "data": base_result_list} return {"status": 200, "msg": "成功", "data": base_result_list}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment