Skip to content

Z
zhichan
Commit 439a8a33 by 黄静
Options

hj

parent a3b01041
Showing with 722 additions and 46 deletions
entprofile/Dataoper.py 0 → 100644
#-*- encoding:utf-8 -*-
#!/usr/bin/python
import pymysql
ip = "47.95.76.74"
port = 3306
database = "ent_data"
user = "root"
password = "Gongsibao2018"
def Getdata(cate_name):
sql = 'select * from tj_policycycle where cate_name = "%s" order by life_cycle' % cate_name
#数据库连接
db = pymysql.Connect(ip, user, password, database, port)
cursor = db.cursor(cursor=pymysql.cursors.DictCursor)
try:
cursor.execute(sql)
re1 = cursor.fetchall()
if re1:
list = []
for ree in re1:
if ree:
policy_name = ree["policy_name"]
life_cycle = ree["life_cycle"]
dict = {}
dict[policy_name] = life_cycle
list.append(dict)
return 1,list
else:
db.close()
return 0, {}
except:
db.close()
return -1, {}
def InsertData(datainfo):
# 数据库连接
db = pymysql.Connect(ip, user, password, database, port)
cursor = db.cursor(cursor=pymysql.cursors.DictCursor)
try:
update_sql = 'update tj_policycycle set life_cycle = %s where id = %s'
insert_sql = 'INSERT INTO `ent_data`.`tj_policycycle` (`cate_name`, `policy_name`, `life_cycle`) VALUES (%s, %s, %s)'
for data in datainfo:
cate_name = data["cate_name"]
policy_name = data["policy_name"]
life_cycle = data["life_cycle"]
select_sql = 'select * from tj_policycycle where cate_name = "%s" and policy_name = "%s"' % (cate_name, policy_name)
cursor.execute(select_sql)
re1 = cursor.fetchone()
if re1:
id = re1["id"]
tub = (life_cycle, id)
cursor.execute(update_sql,tub)
else:
tub = (cate_name, policy_name, life_cycle)
cursor.execute(insert_sql, tub)
db.commit()
db.close()
return 1
except FileExistsError as e:
db.rollback()
db.close()
return 0
# 下面一句的作用1是：运行本程序文件时执行什么操作
if __name__ == "__main__":
# #插入数据库
# datainfo = [
# {"cate_name":"文化、体育和娱乐业","policy_name":"IDC许可证","life_cycle":5},
# {"cate_name": "文化、体育和娱乐业", "policy_name": "EDI许可证", "life_cycle": 3},
# {"cate_name": "信息传输、软件和信息技术服务业", "policy_name": "IDC许可证", "life_cycle": 8},
# ]
#
#
# result = InsertData(datainfo)
# print(str(result))
#查询数据
cate_name = "文化、体育和娱乐业"
re1,re2 = Getdata(cate_name)
print(str(re1))
print(str(re2))
entprofile/GetImageFromSql.py
...@@ -13,10 +13,10 @@ from DBUtils.PooledDB import PooledDB ...@@ -13,10 +13,10 @@ from DBUtils.PooledDB import PooledDB
from flask import request,jsonify from flask import request,jsonify
# 数据库 # 数据库
MYSQL_HOST = '43.247.184.94' #外网地址 MYSQL_HOST = '47.95.76.74' #外网地址
PORT = 9187 #外网端口 PORT = 3306 #外网端口
USER = 'nice' USER = 'root'
PASSWORD = 'Niceee@2020#@' PASSWORD = 'Gongsibao2018'
DB = 'ent_data' DB = 'ent_data'
...@@ -98,15 +98,19 @@ def getImageInfo(server): ...@@ -98,15 +98,19 @@ def getImageInfo(server):
@server.route('/gsb/api/GetHtmlInfoFromSql', methods=['POST']) @server.route('/gsb/api/GetHtmlInfoFromSql', methods=['POST'])
def GetImageInfo(): def GetImageInfo():
print("接口调用--------查询画像标签和产品推荐信息") print("接口调用--------查询画像标签和产品推荐信息")
if request.method == 'POST': result={}
requestdata = request.json try:
print(requestdata) if request.method == 'POST':
companyname = requestdata.get('companyname') requestdata = request.json
companyname = strQ2B(companyname) print(requestdata)
Image_result=GetImageFromSql(companyname) companyname = requestdata.get('companyname')
product_result=GetProductFromSql(companyname) companyname = strQ2B(companyname)
result={"image": Image_result, Image_result = GetImageFromSql(companyname)
"product":product_result} product_result = GetProductFromSql(companyname)
return jsonify(result) result = {"status":200,"msg":"操作成功","image": Image_result,"product": product_result}
except:
result = {"status":404,"msg":"操作失败","image": "-","product": "-"}
return jsonify(result)
# server.run(host='127.0.0.1', port=9001, debug=True) # server.run(host='127.0.0.1', port=9001, debug=True)
\ No newline at end of file
entprofile/Image_status.py
...@@ -12,10 +12,10 @@ from flask import request,jsonify ...@@ -12,10 +12,10 @@ from flask import request,jsonify
"""任务表""" """任务表"""
# # 数据库规则表 # # 数据库规则表
MYSQL_HOST = '43.247.184.94' #外网地址 MYSQL_HOST = '47.95.76.74' #外网地址
PORT = 9187 #外网端口 PORT = 3306 #外网端口
USER = 'nice' USER = 'root'
PASSWORD = 'Niceee@2020#@' PASSWORD = 'Gongsibao2018'
DB = 'ent_data' DB = 'ent_data'
pool = PooledDB(pymysql,8, host=MYSQL_HOST, user=USER, passwd=PASSWORD, db=DB, port=PORT) pool = PooledDB(pymysql,8, host=MYSQL_HOST, user=USER, passwd=PASSWORD, db=DB, port=PORT)
...@@ -169,32 +169,43 @@ def imageInfo(server): ...@@ -169,32 +169,43 @@ def imageInfo(server):
@server.route('/gsb/api/ImageStatusSearch', methods=['POST']) @server.route('/gsb/api/ImageStatusSearch', methods=['POST'])
def ImageStatusSearch(): def ImageStatusSearch():
print("接口调用--------查询画像状态") print("接口调用--------查询画像状态")
if request.method == 'POST': result = {}
requestdata = request.json try:
print(requestdata) if request.method == 'POST':
# 当前页数 requestdata = request.json
pageNum = requestdata.get('pageNum') print(requestdata)
#是否插入表 # 当前页数
insert_status=requestdata.get('insert_status') pageNum = requestdata.get('pageNum')
print(insert_status, type(insert_status), "==========================insert") # 是否插入表
# 每页展示的条数 insert_status = requestdata.get('insert_status')
pageSize = requestdata.get('pageSize') print(insert_status, type(insert_status), "==========================insert")
# 公司名称 # 每页展示的条数
companyName = requestdata.get('companyName') pageSize = requestdata.get('pageSize')
# 提交日期 # 公司名称
currdate=requestdata.get('currdate') companyName = requestdata.get('companyName')
#根据公司名称查询画像标签库、画像状态 # 提交日期
hx_status = GetImageInfoFromSql(companyName) currdate = requestdata.get('currdate')
report_dict = GetReportInfoFromSql(companyName) # 根据公司名称查询画像标签库、画像状态
result={} hx_status = GetImageInfoFromSql(companyName)
if insert_status==1: report_dict = GetReportInfoFromSql(companyName)
WritePRtoSql(companyName, currdate,hx_status,report_dict) if insert_status == 1:
result["result_data"]=GetImageStatusFromSql(companyName,pageSize,pageNum) WritePRtoSql(companyName, currdate, hx_status, report_dict)
result["total"]=work_total(companyName) result["status"] = 200
else: result["msg"] = "操作成功"
result["result_data"] = GetImageStatusFromSql(companyName,pageSize,pageNum) result["result_data"] = GetImageStatusFromSql(companyName, pageSize, pageNum)
result["total"] = work_total(companyName) result["total"] = work_total(companyName)
return jsonify(result) else:
result["status"] = 200
result["msg"] = "操作成功"
result["result_data"] = GetImageStatusFromSql(companyName, pageSize, pageNum)
result["total"] = work_total(companyName)
except:
result["status"] = 404
result["msg"] = "操作失败"
result["result_data"] = "-"
result["total"] = "-"
return jsonify(result)
# server.run(host='127.0.0.1', port=8100, debug=True) # server.run(host='127.0.0.1', port=8100, debug=True)
entprofile/main.py
import flask import flask
from flask_cors import CORS from flask_cors import CORS
from Image_status import imageInfo from Image_status import imageInfo
# from trade import selectcyle,insertcycle
from GetImageFromSql import getImageInfo from GetImageFromSql import getImageInfo
# from online_GetLicenseImage import getlicenceInfo
# from tf_member_es import gaoguan,gudong
server = flask.Flask(__name__) server = flask.Flask(__name__)
server.config['JSON_AS_ASCII'] = False server.config['JSON_AS_ASCII'] = False
CORS(server,supports_credentials=True) #跨域请求 CORS(server,supports_credentials=True) #跨域请求
imageInfo(server) imageInfo(server)
# selectcyle(server)
# insertcycle(server)
getImageInfo(server) getImageInfo(server)
# getlicenceInfo(server)
# gaoguan(server)
# gudong(server)
if __name__ == '__main__': if __name__ == '__main__':
server.run( server.run(
......
entprofile/online_GetLicenseImage.py 0 → 100644
#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Time : 2020/3/14 16:37
# @Author : fanhui
# @File : GetLicenseDataForImage.py
# @Software: PyCharm
from elasticsearch import Elasticsearch
from flask import request,jsonify
"""证照信息"""
esip = "43.247.184.94" #外网地址
# esip1 = "172.16.18.110" #内网地址
esport = 9200
esuser = "admines"
espassword = "adminGSB"
es = Elasticsearch([esip], http_auth=(esuser, espassword), port=esport, timeout=15000) #工商
#检索高新技术企业ES
def GetGXLicensesFromES(companyname):
print("证照es",companyname)
license_result_list=[]
licensesinfo1 = es.search(index="enterprise_chain_gxgy",
body={"query": {"bool": {"must": {"term": {"companyName.raw": companyname}}}}})
print("============111111111111111111")
if licensesinfo1["hits"]["hits"]:
for row in licensesinfo1["hits"]["hits"]:
if row['_source']["techType"]:
license_name="高新技术企业" # 证照名称
else:
license_name = "—" # 证照名称
if row['_source']["certificateNo"]:
certificateNo=row['_source']["certificateNo"]#证照编号
else:
certificateNo = "—" #证照编号
if row['_source']["year"]:
begin_date = row['_source']["year"] # 开始时间
else:
begin_date = "—" #开始时间
license_result = {
"license_name": license_name,
"certificateNo": certificateNo,
"begin_date": begin_date,
"end_date": "—"
}
license_result_list.append(license_result)
return license_result_list
#检索游戏类证照ES
def GetgameLicensesFromES(companyname):
print("游戏类证照es")
license_result_list1=[]
licensesinfo1 = es.search(index="enterprise_chain_game",
body={"query": {"bool": {"must": {"term": {"publishing_unit.raw": companyname}}}}})
if licensesinfo1["hits"]["hits"]:
for row in licensesinfo1["hits"]["hits"]:
if row['_source']["publishing_record"]:
license_name="网络游戏运营备案" # 证照名称
else:
license_name = "—" # 证照名称
if row['_source']["symbol"]:
certificateNo=row['_source']["symbol"]#证照编号
else:
certificateNo = "—" #证照编号
if row['_source']["publish_time"]:
begin_date = row['_source']["publish_time"] # 开始时间
else:
begin_date = "—" #开始时间
license_result = {
"license_name": license_name,
"certificateNo": certificateNo,
"begin_date": begin_date,
"end_date": "—"
}
license_result_list1.append(license_result)
license_result_list2 = []
licensesinfo1 = es.search(index="enterprise_chain_game",
body={"query": {"bool": {"must": {"term": {"operation_unit.raw": companyname}}}}})
if licensesinfo1["hits"]["hits"]:
for row in licensesinfo1["hits"]["hits"]:
if row['_source']["publishing_record"]:
license_name = "网络游戏出版备案" # 证照名称
else:
license_name = "—" # 证照名称
if row['_source']["symbol"]:
certificateNo = row['_source']["symbol"] # 证照编号
else:
certificateNo = "—" # 证照编号
if row['_source']["publish_time"]:
begin_date = row['_source']["publish_time"] # 开始时间
else:
begin_date = "—" # 开始时间
license_result = {
"license_name": license_name,
"certificateNo": certificateNo,
"begin_date": begin_date,
"end_date": "—"
}
license_result_list2.append(license_result)
license_result_list=license_result_list1+license_result_list2
return license_result_list
#检索高新技术企业ES
def GetICPLicensesFromES(companyname):
print("ICP证照es")
license_result_list=[]
licensesinfo1 = es.search(index="enterprise_chain_license",
body={"query": {"bool": {"must": {"term": {"companyName.raw": companyname}}}}})
if licensesinfo1["hits"]["hits"]:
for row in licensesinfo1["hits"]["hits"]:
if row['_source']["licence"]:
license_name=row['_source']["licence"] # 证照名称
else:
license_name = "—" # 证照名称
if row['_source']["licence_no"]:
certificateNo=row['_source']["licence_no"]#证照编号
else:
certificateNo = "—" #证照编号
if row['_source']["start_date"]:
begin_date = row['_source']["start_date"] # 开始时间
else:
begin_date = "—" #开始时间
if row['_source']["end_date"]:
end_date = row['_source']["end_date"] # 截止时间
else:
end_date = "—" #截止时间
license_result = {
"license_name": license_name,
"certificateNo": certificateNo,
"begin_date": begin_date,
"end_date": end_date
}
license_result_list.append(license_result)
return license_result_list
def strQ2B(companyname):
"""公司名称全角转半角"""
name = ""
for uchar in companyname:
inside_code=ord(uchar)
if inside_code == 12288: #全角空格直接转换
inside_code = 32
elif (inside_code >= 65281 and inside_code <= 65374): #全角字符（除空格）根据关系转化
inside_code -= 65248
name += chr(inside_code)
return name
def getlicenceInfo(server):
@server.route('/gsb/api/GetLicenseFromEs', methods=['POST'])
def GetLicenseInfo():
print("接口调用--------查询企业证照信息")
if request.method == 'POST':
requestdata = request.json
print(requestdata)
companyname = requestdata.get('companyname')
companyname = strQ2B(companyname)
LicenseInfo1= GetGXLicensesFromES(companyname)
LicenseInfo2 = GetgameLicensesFromES(companyname)
LicenseInfo3 = GetICPLicensesFromES(companyname)
license_result=LicenseInfo1+LicenseInfo2+LicenseInfo3
return jsonify(license_result)
# server.run(host='172.21.0.2', port=9000, debug=True)
# server.run(host='127.0.0.1', port=9000, debug=True)
\ No newline at end of file
entprofile/tf_member_es.py 0 → 100644
from flask import request
import pymysql
import json
from elasticsearch import Elasticsearch
def getdbdata_gg(input_name):
conn = pymysql.connect(host='47.95.76.74', port=3306, user='root', password='Gongsibao2018', db='ent_data',
charset='utf8')
cur = conn.cursor()
sql_1 = "SELECT company_name,member_name,member_position FROM tj_member where company_name=%s"
sql_2 = "SELECT company_name,shareholder_name,subscription_funds,turn_funds,subscript_type,subscrip_time FROM tj_shareholder where company_name=%s"
cur.execute(sql_1, input_name)
gaoguan = cur.fetchall()
cur.execute(sql_2, input_name)
gudong = cur.fetchall()
conn.close()
return gaoguan
def record2jsion_gg(query_data):
jsonData = []
output = []
for row in query_data:
data = {}
data['company_name'] = str(row[0])
data['member_name'] = str(row[1])
data['member_position'] = str(row[2])
jsonData.append(data)
jsondatar = json.dumps(jsonData, ensure_ascii=False)
# output=json.loads(jsondatar)#本机python环境需要加上
output = jsondatar
return output
def getdbdata_gd(input_name):
conn = pymysql.connect(host='47.95.76.74', port=3306, user='root', password='Gongsibao2018', db='ent_data',
charset='utf8')
cur = conn.cursor()
sql_1 = "SELECT company_name,member_name,member_position FROM tj_member where company_name=%s"
sql_2 = "SELECT company_name,shareholder_name,subscription_funds,turn_funds,subscript_type,subscrip_time FROM tj_shareholder where company_name=%s"
cur.execute(sql_1, input_name)
gaoguan = cur.fetchall()
cur.execute(sql_2, input_name)
gudong = cur.fetchall()
conn.close()
return gudong
def record2jsion_gd(query_data):
jsonData = []
output = []
for row in query_data:
data = {}
data['company_name'] = str(row[0])
data['shareholder_name'] = str(row[1])
data['subscription_funds'] = str(row[2])
data['turn_funds'] = str(row[3])
data['subscript_type'] = str(row[4])
data['subscrip_time'] = str(row[5])
jsonData.append(data)
jsondatar = json.dumps(jsonData, ensure_ascii=False)
# output=json.loads(jsondatar)#本机python环境需要加上
output = jsondatar
return output
# list_copy=[{1},{2},{3},{3},{2},{1}]#去除重复远素
def distinct_list(list_copy):
new_list = []
for k in list_copy:
if k not in new_list:
new_list.append(k)
# print("方法三：", new_list)
return new_list
class ElasticObj(object):
def __init__(self, index_name, index_type, ip="43.247.184.94"):
'''
:param index_name: 索引名称
:param index_type: 索引类型
'''
self.index_name = index_name
self.index_type = index_type
self.es = Elasticsearch([ip], http_auth=('admines', 'adminGSB.'), port=9200)
def Get_Data_By_Body(self, company_name):
doc = {"query": {"match": {"companyName": company_name}}}
# doc = {"query":{"match": {"companyName":"北京华泰丽成智能科技有限公司"}}}
_searched = self.es.search(index=self.index_name, doc_type=self.index_type, body=doc)
temp = []
for hit in _searched['hits']['hits']:
print("Got %d Hits:" % _searched['hits']['total'])
# print (hit['_source'])
# print (hit['_source']['companyName'])
t = hit['_source']
temp.append(t)
# tt=es_records[0]['_source']
# print(tt)
# print(json.dumps(es_records,ensure_ascii=False))
tt = temp
return tt # [tt]
def Get_Data_By_Body_Input(self, match_field, field_cotent):
doc = {"query": {"match": {match_field: field_cotent}}}
# doc = {"query":{"match": {"companyName":"北京华泰丽成智能科技有限公司"}}}
_searched = self.es.search(index=self.index_name, doc_type=self.index_type, body=doc)
temp = []
for hit in _searched['hits']['hits']:
# print("Got %d Hits:" % _searched['hits']['total'])
# print (hit['_source'])
# print (hit['_source']['companyName'])
t = hit['_source']
temp.append(t)
# tt=es_records[0]['_source']
# print(tt)
# print(json.dumps(es_records,ensure_ascii=False))
tt = temp
return tt # [tt]
def Get_Data_Return_Body_ID(self, match_field, field_cotent):
# doc = {"query":{"match": {match_field:field_cotent}}}
# doc = {"query":{"match": {match_field:field_cotent}}}
doc = {"query": {"match": {match_field: field_cotent}}, "size": 1, "_source": ["_id"]}
# doc={"query": {"match": {"company_name": "北京非常满意科技有限公司"}},"size": 1}
# doc = {"query":{"match": {"companyName":"北京华泰丽成智能科技有限公司"}}}
_searched = self.es.search(index=self.index_name, doc_type=self.index_type, body=doc)
temp = []
for hit in _searched['hits']['hits']:
# print("Got %d Hits:" % _searched['hits']['total'])
# print (hit['_source'])
# print (hit['_source']['companyName'])
t = hit['_id']
temp.append(t)
# tt=es_records[0]['_source']
# print(tt)
# print(json.dumps(es_records,ensure_ascii=False))
tt = temp
return tt # [tt]
def search_gaoguan(input_company_name):
company_info = ElasticObj("bigdata_ic_gsb_company_04", "_doc") # 初始化索引
match_field_0 = 'company_name'
field_cotent_0 = input_company_name
# field_cotent_0='北京非常满意科技有限公司'
# field_cotent1='83468156'
company_id = company_info.Get_Data_Return_Body_ID(match_field_0, field_cotent_0) # 返回查询结果
# print('OK--company_info->\n')
# print(company_id)
if company_id:
company_staff = ElasticObj("bigdata_ic_gsb_staff", "_doc") # 初始化索引
match_field1 = 'company_id'
# field_cotent1='83468156'
field_cotent1 = company_id[0]
staff_info = company_staff.Get_Data_By_Body_Input(match_field1, field_cotent1) # 返回查询结果
# print('OK--staff_info->\n')
# print(staff_info)
# print(staff_info[0]['branch_id'])
for num in staff_info:
# print(num['branch_id'])
pass
human_name = ElasticObj("bigdata_ic_gsb_human", "_doc") # 嵌套查询另一个索引
for i in range(0, len(staff_info)):
if staff_info[i]:
# print(staff_info[i]['staff_id'])
# human_name= ElasticObj("bigdata_ic_gsb_company_04", "_doc")
ss = human_name.Get_Data_By_Body_Input('id', staff_info[i]['staff_id']) # 返回子查询结果
# print('OK-human_info-->\n')
# print(ss[0]['name'])
if ss[0]['name']: # 返回值不为空
staff_info[i]['staff_id'] = ss[0]['name'] # 替换相应的值
# print(staff_info[i])
else:
print('no data!')
# print('\n--->\n')
# print(staff_info)
finall_key = {'company_id', 'staff_id', 'staff_type_name'}
finall_info = []
# OO=[]
# ord_dict=OrderedDict()
for j in range(0, len(staff_info)):
staff_info[j]['company_id'] = field_cotent_0
finall_info.append({key: value for key, value in staff_info[j].items() if key in finall_key})
finall_info[j].update({'company_name': finall_info[j].pop('company_id')}) # 修改键名
# finall_info[j].update({'staff_name':finall_info[j].pop('staff_id')})
finall_info[j].update({'member_name': finall_info[j].pop('staff_id')})
finall_info[j].update({'member_position': finall_info[j].pop('staff_type_name')})
# ord_dict['company_name']=finall_info[j]['company_name']
# ord_dict['staff_name']=finall_info[j]['staff_name']
# ord_dict['staff_type_name']=finall_info[j]['staff_type_name']
# OO[j]=ord_dict[0]
# print('\n--final_result!->\n')
# print([finall_info[3]])
# print(finall_info)
return finall_info
def search_gudong(input_company_name):
annual_info = ElasticObj("bigdata_ic_gsb_annualreport", "_doc") # 初始化索引
match_field_0 = 'company_name'
field_cotent_0 = input_company_name
# field_cotent1='83468156' 2914053007
annual_id = annual_info.Get_Data_Return_Body_ID(match_field_0, field_cotent_0) # 返回查询结果
# print('OK--company_info->\n')
# print(annual_id)
# print(max(annual_id))
# print('\n')
# print(sorted(annual_id,reverse=True))
shareholder_info = ElasticObj("bigdata_ic_gsb_shareholder_1", "_doc") # 初始化索引
match_field1 = 'annual_report_id'
# field_cotent1='83468156'
# field_cotent1=max(annual_id)
for i in range(0, len(annual_id)):
order_annual_id = sorted(annual_id, reverse=True)
field_cotent1 = order_annual_id[i]
# print('field_content_1')
# print(field_cotent1)
company_shareholder = shareholder_info.Get_Data_By_Body_Input(match_field1, field_cotent1) # 返回查询结果
if company_shareholder:
break
# print('OK--staff_info->\n')
# print(company_shareholder)
# break
finall_key = {'gsb_company_name', 'investor_name', 'subscribe_amount', 'subscribe_time', 'subscribe_type',
'paid_amount', 'paid_time', 'paid_type'}
# finall_key={'gsb_company_name','investor_name','subscribe_amount','subscribe_time','subscribe_type','paid_amount'}
finall_info = []
# OO=[]
# ord_dict=OrderedDict()
for j in range(0, len(company_shareholder)):
company_shareholder[j]['gsb_company_name'] = field_cotent_0
finall_info.append({key: value for key, value in company_shareholder[j].items() if key in finall_key})
finall_info[j].update({'company_name': finall_info[j].pop('gsb_company_name')})
finall_info[j].update({'shareholder_name': finall_info[j].pop('investor_name')})
finall_info[j].update({'subscription_funds': finall_info[j].pop('subscribe_amount')})
finall_info[j].update({'turn_funds': finall_info[j].pop('paid_amount')})
finall_info[j].update({'subscript_type': finall_info[j].pop('subscribe_type')})
finall_info[j].update({'subscrip_time': finall_info[j].pop('subscribe_time')})
#
finall_info[j].update({'ture_subscrpt_time': finall_info[j].pop('paid_time')})
finall_info[j].update({'ture_subscript_type': finall_info[j].pop('paid_type')})
# ord_dict['company_name']=finall_info[j]['company_name']
# ord_dict['staff_name']=finall_info[j]['staff_name']
# ord_dict['staff_type_name']=finall_info[j]['staff_type_name']
# OO[j]=ord_dict[0]
# print('\n--final_result!->\n')
# print([finall_info[3]])
# print(finall_info)
return finall_info # json.dumps(finall_info,ensure_ascii=False)
# @app.route('/',methods=['GET', 'POST'])
def gaoguan(server):
@server.route('/api/gaoguan', methods=['POST'])
def index():
if request.method == 'POST':
request_data = request.json
inputs = request_data.get('company_name')
# gaoguan=getdbdata_gg(inputs)
gaoguan = search_gaoguan(inputs)
json.dumps(gaoguan, ensure_ascii=False)
# outputs=record2jsion_gg(gaoguan)
return json.dumps(gaoguan, ensure_ascii=False) # gaoguan #outputs
'''def index():
if request.method=='POST':
request_data=request.json
inputs=request_data.get('company_name')
gaoguan=getdbdata_gg(inputs)
outputs=record2jsion_gg(gaoguan)
return outputs'''
def gudong(server):
@server.route('/api/gudong', methods=['POST'])
def indexx():
if request.method == 'POST':
request_data = request.json
inputs = request_data.get('company_name')
# gaoguan=getdbdata_gd(inputs)
gudong = search_gudong(inputs)
# outputs_gd=record2jsion_gd(gaoguan)
# json.dumps(gudong,ensure_ascii=False)
# return outputs_gd
return json.dumps(gudong, ensure_ascii=False)
'''def indexx():
if request.method=='POST':
request_data=request.json
inputs=request_data.get('company_name')
gaoguan=getdbdata_gd(inputs)
outputs_gd=record2jsion_gd(gaoguan)
return outputs_gd '''
'''
def index():
gaoguan=getdbdata(input_name)
output=record2jsion(gaoguan)
return output'''
# if __name__ == '__main__':
# app.run(debug=True)
# input_name='北京格尔法网络科技有限公司'
# app.run(debug=True)
# result=index()
# print(result[0])
entprofile/trade.py 0 → 100644
#!/usr/bin/env python
# -*- coding: utf-8 -*-
from flask import request
from elasticsearch import Elasticsearch
import json
import Dataoper
# es连接信息
esip = "43.247.184.94"
esport = 9200
# esip = "172.16.18.110"
# esport = 9203
esuser = "admines"
espassword = "adminGSBes"
es = Elasticsearch([esip], http_auth=(esuser, espassword), port=esport,timeout=1000)
def selectcyle(server):
@server.route("/api/selectcycle",methods = ['POST'])
def getCompanyTrade():
try:
companyNames=request.get_json().get("company_name")
querybody={
"query": {
"bool": {
"must": [
{
"term": {
"company_name.raw": companyNames
}
}
]
}
}
}
searched = es.search(index='bigdata_ic_gsb_company_02', doc_type='_doc', body=querybody)
if searched["hits"]["total"]:
company_cate_1 = searched["hits"]["hits"][0]['_source']["gsb_company_cate_1"] # 行业第一大类
company_cate_2 = searched["hits"]["hits"][0]['_source']["gsb_company_cate_2"] # 行业第二大类
company_cate_3 = searched["hits"]["hits"][0]['_source']["gsb_company_cate_3"] # 行业第三大类
re1,re2 = Dataoper.Getdata(company_cate_1)
if re1:
return json.dumps({"status": 0, "msg":"操作成功","data": re2}, ensure_ascii=False)
else:
return json.dumps({"status": -1, "msg":"没有对应的证照信息","data": []}, ensure_ascii=False)
else:
return json.dumps({"status": -1, "msg":"没有对应工商信息","data": []}, ensure_ascii=False)
except:
return json.dumps({"status": -1, "msg":"调用服务出错","data": []}, ensure_ascii=False)
def insertcycle(server):
@server.route("/api/insertcycle",methods = ['POST'])
def putCompanyTrade():
try:
data=request.get_json().get("data")
print(data)
re1=Dataoper.InsertData(data)
if re1 :
return json.dumps({"status": 0, "msg":"成功","data": re1}, ensure_ascii=False)
else:
return json.dumps({"status": -1, "msg":"失败","data": 0}, ensure_ascii=False)
except:
return json.dumps({"status": -1, "msg":"调用服务出错","data": {}}, ensure_ascii=False)
\ No newline at end of file
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