Skip to content

M
mancheng
Commit bb4eda25 by 赵宇
Options

fix

parent cf78e5c0
Showing with 243 additions and 208 deletions
apps/atlas/view.py
...@@ -133,98 +133,6 @@ ...@@ -133,98 +133,6 @@
# return jsonify(code=RET.OK, msg="获取成功", options=data) # return jsonify(code=RET.OK, msg="获取成功", options=data)
# #
# #
# # 太原市企业列表
# @api_atlas.route('/industry/enterprise', methods=['POST'])
# # @login_required
# def enterprise():
# '''太原市企业列表'''
# req_dict = request.get_json()
# inid = req_dict.get("inid") # 行业id
# cate = req_dict.get("cate") # 行业等级,（高端设备等五个为"1",子行业为"2"）
# page = req_dict.get("page") # 分页页码
# perpage = req_dict.get("perpage") # 分页大小
#
# entype = req_dict.get("entype") # 企业类型id
# qualificat = req_dict.get("qualificat") # 企业资质id
# capital = req_dict.get("capital") # 注册资本id
# quoted = req_dict.get("quoted") # 上市板块
# district = req_dict.get("district") # 太原市下区县
# yearid = req_dict.get("yearid") # 成立时间年限id
# roundid = req_dict.get("roundid") # 融资轮次id(天使/种子，1)（PreA/A+,2）（PreB/B+,3）(C轮以上，4)（收并购，5）（战略投资，6）（其他，7）
# product = req_dict.get("product") # 产业产品选择
# company_name = req_dict.get("company_name") # 产业产品名称筛选
# sorts = req_dict.get("sorts") # 排序 sorts "1"按时间降序 ，“2”按热度降序
#
# # 校验参数完整性
# if not all([inid, cate, page, perpage]):
# return jsonify(code=RET.PARAMERR, msg="参数不完整")
#
# try:
# if cate == "1":
# company = Company.query.filter_by(f_type=inid, city="太原市")
# else:
# company = Company.query.filter_by(c_type=inid, city="太原市")
# # 企业类型
# if entype:
# company = company.filter_by(entypeid=entype)
# # 企业资质
# if qualificat:
# if qualificat == 1:
# company = company.filter_by(high_new=1)
# if qualificat == 2:
# company = company.filter_by(tbe=1)
# if qualificat == 3:
# company = company.filter_by(quoted_company=1)
# if qualificat == 4:
# company = company.filter_by(sxonhun=1)
# if qualificat == 5:
# company = company.filter_by(isfive=1)
# if qualificat == 6:
# company = company.filter_by(unicorn=1)
# if qualificat == 7:
# company = company.filter_by(dengl=1)
# if qualificat == 8:
# company = company.filter_by(zjtg=1)
# if qualificat == 9:
# company = company.filter_by(scale=1)
# if qualificat == 10:
# company = company.filter_by(serve=1)
# # 注册资本
# if capital:
# company = company.filter_by(capital_id=capital)
# # 上市板块
# if quoted:
# company = company.filter_by(public_id=quoted)
# # 区域选择
# if district:
# company = company.filter_by(district=district)
# # 成立时间id
# if yearid:
# company = company.filter_by(yearid=yearid)
# # 融资轮次
# if roundid:
# company = company.filter_by(roundid=roundid)
# if company_name:
# company = company.filter(Company.company_name.like("%{}%".format(company_name)))
# if product:
# company = Company.query.filter(Company.product_all.like("%{}%".format(product)))
# size = company.count()
# if sorts == "1":
# companys = company.order_by(Company.build_date.desc()).paginate(page, perpage).items # 企业热度倒序
# else:
# companys = company.order_by(Company.hots.desc()).paginate(page, perpage).items # 企业热度倒序
#
# df = [{"id": i.id,
# "company_name": i.company_name,
# "hots": i.hots} for i in companys]
# data = {"size": size, "df": df}
# except Exception as e:
# current_app.logger.error(e)
# return jsonify(code=RET.DBERR, msg="数据库查询错误")
#
# return jsonify(code=RET.OK, msg="获取成功", data=data)
#
#
# # 行业信息总览 # # 行业信息总览
# @api_atlas.route('/industry/overview', methods=['POST']) # @api_atlas.route('/industry/overview', methods=['POST'])
# # @login_required # # @login_required
......
apps/atlas/view_graph.py
...@@ -70,6 +70,25 @@ def find_up_thr(name_query, relation): ...@@ -70,6 +70,25 @@ def find_up_thr(name_query, relation):
return data return data
# 获取产业集群名称
@api_atlas.route('/industry/cluster', methods=['GET'])
def get_cluster():
try:
cluster_obj = Industry.query.filter_by(fid=0).all()
data = {
"cluster": [
{"id": i.nid, 'industry_level': 1, 'name': i.name,
"subNodeList": [{'id': j.nid, 'industry_level': 2, "name": j.name} for j in
Industry.query.filter_by(fid=i.nid)]} for i in
cluster_obj]
}
return jsonify(code=RET.OK, msg='产业集群名称获取成功！', data=data)
except Exception as e:
current_app.logger.error(e)
# 行业产品公司数量(链图,根据地理位置) # 行业产品公司数量(链图,根据地理位置)
@api_atlas.route('/industry/chain', methods=['POST']) @api_atlas.route('/industry/chain', methods=['POST'])
# @login_required # @login_required
...@@ -80,7 +99,7 @@ def industry_chain(): ...@@ -80,7 +99,7 @@ def industry_chain():
''' '''
req_dict = request.get_json() req_dict = request.get_json()
inid = req_dict.get("inid") # 二级行业id（二级行业显示链图） inid = req_dict.get("inid") # 二级行业id（二级行业显示链图）
district = req_dict.get("district") # 区县 # district = req_dict.get("district") # 区县
# 校验参数完整性 # 校验参数完整性
if not all([inid]): if not all([inid]):
...@@ -121,82 +140,44 @@ def industry_enterprise(): ...@@ -121,82 +140,44 @@ def industry_enterprise():
'''骨干企业数据''' '''骨干企业数据'''
req_dict = request.get_json() req_dict = request.get_json()
inid = req_dict.get("inid") # 行业id inid = req_dict.get("inid") # 行业id
cate = req_dict.get("cate") # 行业等级,（高端设备等五个为"1",子行业为"2"） industry_level = req_dict.get("industry_level") # 行业等级,（父行个为"1",子行业为"2"）
page = req_dict.get("page") # 分页页码 page = req_dict.get("page") # 分页页码
perpage = req_dict.get("perpage") # 分页大小 perpage = req_dict.get("perpage") # 分页大小
# entype = req_dict.get("entype") # 企业类型id # sorts = req_dict.get("sorts") # 排序 sorts "1"按时间降序 ，“2”按热度降序
# qualificat = req_dict.get("qualificat") # 企业资质id
# capital = req_dict.get("capital") # 注册资本id
# quoted = req_dict.get("quoted") # 上市板块
# district = req_dict.get("district") # 太原市下区县
# yearid = req_dict.get("yearid") # 成立时间年限id
# roundid = req_dict.get("roundid") # 融资轮次id(天使/种子，1)（PreA/A+,2）（PreB/B+,3）(C轮以上，4)（收并购，5）（战略投资，6）（其他，7）
# product = req_dict.get("product") # 产业产品选择
# company_name = req_dict.get("company_name") # 产业产品名称筛选
sorts = req_dict.get("sorts") # 排序 sorts "1"按时间降序 ，“2”按热度降序
# 校验参数完整性 # 校验参数完整性
if not all([inid, cate, page, perpage]): if not all([inid, industry_level, page, perpage]):
return jsonify(code=RET.PARAMERR, msg="参数不完整") return jsonify(code=RET.PARAMERR, msg="参数不完整")
try: try:
if cate == "1": if industry_level == 1:
company = Company.query.filter_by(f_type=inid, city="晋城市") company = Company.query.filter_by(f_type=inid, city="晋城市")
else: else:
company = Company.query.filter_by(c_type=inid, city="晋城市") company = Company.query.filter_by(c_type=inid, city="晋城市")
# # 企业类型
# if entype:
# company = company.filter_by(entypeid=entype)
# # 企业资质
# if qualificat:
# if qualificat == 1:
# company = company.filter_by(high_new=1)
# if qualificat == 2:
# company = company.filter_by(tbe=1)
# if qualificat == 3:
# company = company.filter_by(quoted_company=1)
# if qualificat == 4:
# company = company.filter_by(sxonhun=1)
# if qualificat == 5:
# company = company.filter_by(isfive=1)
# if qualificat == 6:
# company = company.filter_by(unicorn=1)
# if qualificat == 7:
# company = company.filter_by(dengl=1)
# if qualificat == 8:
# company = company.filter_by(zjtg=1)
# if qualificat == 9:
# company = company.filter_by(scale=1)
# if qualificat == 10:
# company = company.filter_by(serve=1)
# # 注册资本
# if capital:
# company = company.filter_by(capital_id=capital)
# # 上市板块
# if quoted:
# company = company.filter_by(public_id=quoted)
# # 区域选择
# if district:
# company = company.filter_by(district=district)
# # 成立时间id
# if yearid:
# company = company.filter_by(yearid=yearid)
# # 融资轮次
# if roundid:
# company = company.filter_by(roundid=roundid)
# if company_name:
# company = company.filter(Company.company_name.like("%{}%".format(company_name)))
# if product:
# company = Company.query.filter(Company.product_all.like("%{}%".format(product)))
size = company.count() size = company.count()
if sorts == "1": # if sorts == 1:
companys = company.order_by(Company.build_date.desc()).paginate(page, perpage).items # 企业热度倒序 # companys = company.order_by(Company.build_date.desc()).paginate(page, perpage).items # 企业热度倒序
else: # else:
companys = company.order_by(Company.hots.desc()).paginate(page, perpage).items # 企业热度倒序 companys = company.order_by(Company.hots.desc()).paginate(page, perpage).items # 企业热度倒序
df = [{"id": i.id, df = [{"id": i.id,
"company_name": i.company_name, "company_name": i.company_name,
"hots": i.hots} for i in companys] "district": i.district,
"build_date": i.build_date,
"legal": i.legal,
"capital_nums": i.capital_nums,
"entype": i.entype,
"address": i.address,
"telephone": i.telephone,
"high_new": '高新技术企业' if i.high_new == '1' else '',
"tbe": '科技型中小企业' if i.tbe == '1' else '',
"quoted_company": '上市企业' if i.quoted_company == '1' else '',
"zjtg": '精专特新企业' if i.zjtg == '1' else '',
"unicorn": '独角兽企业' if i.unicorn == '1' else '',
"dengl": '瞪羚企业' if i.dengl == '1' else '',
"isfive": '五百强企业' if i.isfive == '1' else '',
"scale": '规模以上企业' if i.scale == '1' else ''
} for i in companys]
data = {"size": size, "df": df} data = {"size": size, "df": df}
except Exception as e: except Exception as e:
current_app.logger.error(e) current_app.logger.error(e)
...@@ -226,7 +207,7 @@ def industry_resource(): ...@@ -226,7 +207,7 @@ def industry_resource():
if select_flag == 1: # 高等院校 if select_flag == 1: # 高等院校
try: try:
if industry_level == "1": if industry_level == 1:
college = College.query.filter(College.navigator.like("%{}%".format(name))) college = College.query.filter(College.navigator.like("%{}%".format(name)))
else: else:
college = College.query.filter(College.navigat.like("%{}%".format(name))) college = College.query.filter(College.navigat.like("%{}%".format(name)))
...@@ -249,7 +230,7 @@ def industry_resource(): ...@@ -249,7 +230,7 @@ def industry_resource():
current_app.logger.error(e) current_app.logger.error(e)
return jsonify(code=RET.DATAERR, msg="参数错误") return jsonify(code=RET.DATAERR, msg="参数错误")
elif select_flag == 2: # 科研机构 elif select_flag == 2: # 科研机构
if industry_level == "1": if industry_level == 1:
scientific = Scientific.query.filter(Scientific.navigator.like("%{}%".format(name))) scientific = Scientific.query.filter(Scientific.navigator.like("%{}%".format(name)))
else: else:
scientific = Scientific.query.filter(Scientific.navigat.like("%{}%".format(name))) scientific = Scientific.query.filter(Scientific.navigat.like("%{}%".format(name)))
...@@ -265,7 +246,7 @@ def industry_resource(): ...@@ -265,7 +246,7 @@ def industry_resource():
"size": size} "size": size}
return jsonify(code=RET.OK, msg="查询成功", data=data) return jsonify(code=RET.OK, msg="查询成功", data=data)
elif select_flag == 3: # 创新平台3 elif select_flag == 3: # 创新平台3
if industry_level == "1": if industry_level == 1:
lab = Lab.query.filter(Lab.navigator.like("%{}%".format(name))) lab = Lab.query.filter(Lab.navigator.like("%{}%".format(name)))
else: else:
lab = Lab.query.filter(Lab.navigat.like("%{}%".format(name))) lab = Lab.query.filter(Lab.navigat.like("%{}%".format(name)))
...@@ -287,7 +268,7 @@ def industry_resource(): ...@@ -287,7 +268,7 @@ def industry_resource():
def get_data(name, industry_level, select_flag, page, perpage): def get_data(name, industry_level, select_flag, page, perpage):
try: try:
if select_flag in [1, 2]: # 当选择行政区/园区时 if select_flag in [1, 2]: # 当选择行政区/园区时
if industry_level == "1": # 当选择的是父产业时 if industry_level == 1: # 当选择的是父产业时
induzone = Induzone.query.filter(Induzone.navigator.like("%{}%".format(name))) induzone = Induzone.query.filter(Induzone.navigator.like("%{}%".format(name)))
else: # 当选择的是子产业时 else: # 当选择的是子产业时
induzone = Induzone.query.filter(Induzone.navigat.like("%{}%".format(name))) induzone = Induzone.query.filter(Induzone.navigat.like("%{}%".format(name)))
...@@ -298,7 +279,10 @@ def get_data(name, industry_level, select_flag, page, perpage): ...@@ -298,7 +279,10 @@ def get_data(name, industry_level, select_flag, page, perpage):
# 封装行政区数据 # 封装行政区数据
admin_data = {"admin_data": [{ admin_data = {"admin_data": [{
"id": i.id, "id": i.id,
"region": i.region, "image": i.image,
# "region": i.region,
"region": i.name,
"cate": i.cate, # 园区类型
"area": i.area, "area": i.area,
"address": i.address, "address": i.address,
"cluster": i.cluster} for i in induzone], "cluster": i.cluster} for i in induzone],
...@@ -318,7 +302,7 @@ def get_data(name, industry_level, select_flag, page, perpage): ...@@ -318,7 +302,7 @@ def get_data(name, industry_level, select_flag, page, perpage):
return garden_data return garden_data
if select_flag == 3: # 当选择载体土地时 if select_flag == 3: # 当选择载体土地时
if industry_level == "1": # 当选择的是父产业时 if industry_level == 1: # 当选择的是父产业时
land = ZaitiLand.query.filter(ZaitiLand.navigator.like("%{}%".format(name))) land = ZaitiLand.query.filter(ZaitiLand.navigator.like("%{}%".format(name)))
else: else:
land = ZaitiLand.query.filter(ZaitiLand.navigat.like("%{}%".format(name))) land = ZaitiLand.query.filter(ZaitiLand.navigat.like("%{}%".format(name)))
...@@ -338,7 +322,7 @@ def get_data(name, industry_level, select_flag, page, perpage): ...@@ -338,7 +322,7 @@ def get_data(name, industry_level, select_flag, page, perpage):
return land_data return land_data
if select_flag == 4: # 当选择载体楼宇时 if select_flag == 4: # 当选择载体楼宇时
if industry_level == "1": # 当选择的是父产业时 if industry_level == 1: # 当选择的是父产业时
build = ZaitiBuild.query.filter(ZaitiBuild.navigator.like("%{}%".format(name))) build = ZaitiBuild.query.filter(ZaitiBuild.navigator.like("%{}%".format(name)))
else: else:
build = ZaitiBuild.query.filter(ZaitiBuild.navigat.like("%{}%".format(name))) build = ZaitiBuild.query.filter(ZaitiBuild.navigat.like("%{}%".format(name)))
...@@ -360,7 +344,7 @@ def get_data(name, industry_level, select_flag, page, perpage): ...@@ -360,7 +344,7 @@ def get_data(name, industry_level, select_flag, page, perpage):
return build_data return build_data
if select_flag == 5: # 当选择载体厂房时 if select_flag == 5: # 当选择载体厂房时
if industry_level == "1": # 当选择的是父产业时 if industry_level == 1: # 当选择的是父产业时
factory = ZaitiFactory.query.filter(ZaitiFactory.navigator.like("%{}%".format(name))) factory = ZaitiFactory.query.filter(ZaitiFactory.navigator.like("%{}%".format(name)))
else: else:
factory = ZaitiFactory.query.filter(ZaitiFactory.navigat.like("%{}%".format(name))) factory = ZaitiFactory.query.filter(ZaitiFactory.navigat.like("%{}%".format(name)))
...@@ -373,7 +357,7 @@ def get_data(name, industry_level, select_flag, page, perpage): ...@@ -373,7 +357,7 @@ def get_data(name, industry_level, select_flag, page, perpage):
"id": i.id, "id": i.id,
"name": i.name, "name": i.name,
"acreage": i.acreage, "acreage": i.acreage,
"buide_type": i.buide_type, "factory_type": i.factory_type,
"industry_type": i.industry_type, "industry_type": i.industry_type,
"telephone": i.telephone, "telephone": i.telephone,
"addr": i.addr, "addr": i.addr,
...@@ -401,20 +385,20 @@ def industry_zaiti(): ...@@ -401,20 +385,20 @@ def industry_zaiti():
if not all([page, perpage]): if not all([page, perpage]):
return jsonify(code=RET.PARAMERR, msg="参数不完整") return jsonify(code=RET.PARAMERR, msg="参数不完整")
if inid: # if inid:
name = Industry.query.filter_by(nid=inid).first().oname # 获取导航对应的真名 name = Industry.query.filter_by(nid=inid).first().oname # 获取导航对应的真名
try: try:
data = get_data(name, industry_level, select_flag, page, perpage) data = get_data(name, industry_level, select_flag, page, perpage)
return jsonify(code=RET.OK, msg="数据查询成功", data=data) return jsonify(code=RET.OK, msg="数据查询成功", data=data)
except Exception as e: except Exception as e:
current_app.logger.error(e) current_app.logger.error(e)
else: # else:
name = '煤层气' # 默认页面为煤层气的数据 # name = '煤层气' # 默认页面为煤层气的数据
try: # try:
data = get_data(name, "1", 1, page, perpage) # data = get_data(name, 1, 1, page, perpage)
return jsonify(code=RET.OK, msg="数据查询成功", data=data) # return jsonify(code=RET.OK, msg="数据查询成功", data=data)
except Exception as e: # except Exception as e:
current_app.logger.error(e) # current_app.logger.error(e)
# 产业政策 # 产业政策
...@@ -434,11 +418,11 @@ def industry_policy(): ...@@ -434,11 +418,11 @@ def industry_policy():
indu_policy = '' indu_policy = ''
size = '' size = ''
name = Industry.query.filter_by(nid=inid).first().oname # 获取导航对应的真名 name = Industry.query.filter_by(nid=inid).first().oname # 获取导航对应的真名
if industry_level == "1": if industry_level == 1:
indu_policy = InduPolicy.query.filter(InduPolicy.navigator.like("%{}%".format(name))) indu_policy = InduPolicy.query.filter(InduPolicy.navigator.like("%{}%".format(name)))
size = indu_policy.count() # 分页总数 size = indu_policy.count() # 分页总数
indu_policy = indu_policy.paginate(page, perpage).items indu_policy = indu_policy.paginate(page, perpage).items
if industry_level == "2": if industry_level == 2:
indu_policy = InduPolicy.query.filter(InduPolicy.navigat.like("%{}%".format(name))) indu_policy = InduPolicy.query.filter(InduPolicy.navigat.like("%{}%".format(name)))
size = indu_policy.count() # 分页总数 size = indu_policy.count() # 分页总数
indu_policy = indu_policy.paginate(page, perpage).items indu_policy = indu_policy.paginate(page, perpage).items
...@@ -452,13 +436,19 @@ def industry_policy(): ...@@ -452,13 +436,19 @@ def industry_policy():
"id": i.id, "id": i.id,
"name": i.name, "name": i.name,
"org": i.org, "org": i.org,
"pubdate": i.pubdate "pubdate": (i.pubdate).strftime("%Y-%m-%d %H:%M:%S")
} for i in indu_policy], } for i in indu_policy],
"size": size "size": size
} }
return jsonify(code=RET.OK, msg="政策数据查询成功", data=policy_data) return jsonify(code=RET.OK, msg="政策数据查询成功", data=policy_data)
# 产业政策详情信息-复用招商驾驶舱政策详情接口
# 骨干企业详情信息
# 创新资源-高等院校详情 # 创新资源-高等院校详情
@api_atlas.route('/innovate/college_detail', methods=['POST']) @api_atlas.route('/innovate/college_detail', methods=['POST'])
def get_college_detail(): def get_college_detail():
...@@ -478,6 +468,8 @@ def get_college_detail(): ...@@ -478,6 +468,8 @@ def get_college_detail():
"ccode": college.ccode, # 学校代码 "ccode": college.ccode, # 学校代码
"feature": college.feature, # 学校特色 "feature": college.feature, # 学校特色
"research": college.research, # 研究方向 "research": college.research, # 研究方向
"major": college.major,
"faculty": college.faculty,
"lng": college.lng, # 经度 "lng": college.lng, # 经度
"lat": college.lat # 纬度 "lat": college.lat # 纬度
} }
...@@ -531,14 +523,28 @@ def get_lab_detail(): ...@@ -531,14 +523,28 @@ def get_lab_detail():
current_app.logger.error(e) current_app.logger.error(e)
# 产业载体-行政区详情信息 # 产业载体-各类型详情信息
@api_atlas.route('/carrier/zaiti_detail', methods=['POST']) @api_atlas.route('/carrier/zaiti_detail', methods=['POST'])
def get_zaiti_detail_data(): def get_zaiti_detail_data():
req_dict = request.get_json() req_dict = request.get_json()
id = req_dict.get('id') id = req_dict.get('id')
cate_id = req_dict.get('cate_id') # 1为行政区，2为园区，3为土地，4为楼宇，5为厂房 cate_id = req_dict.get('cate_id') # 1为行政区，2为园区，3为土地，4为楼宇，5为厂房
print(cate_id) print(cate_id)
if cate_id == 1: # if cate_id == 1:
# try:
# induzone = Induzone.query.filter_by(id=id).first()
# data = {
# "district": induzone.district,
# "cate": induzone.cate,
# "area": induzone.area,
# "address": induzone.address,
# "cluster": induzone.cluster
# }
# return jsonify(code=RET.OK, msg='行政区详情查询成功！', data=data)
# except Exception as e:
# current_app.logger.error(e)
if cate_id in [1, 2]:
try: try:
induzone = Induzone.query.filter_by(id=id).first() induzone = Induzone.query.filter_by(id=id).first()
data = { data = {
...@@ -546,23 +552,15 @@ def get_zaiti_detail_data(): ...@@ -546,23 +552,15 @@ def get_zaiti_detail_data():
"cate": induzone.cate, "cate": induzone.cate,
"area": induzone.area, "area": induzone.area,
"address": induzone.address, "address": induzone.address,
"cluster": induzone.cluster "cluster": induzone.cluster,
}
return jsonify(code=RET.OK, msg='行政区详情查询成功！', data=data)
except Exception as e:
current_app.logger.error(e)
if cate_id == 2:
try:
induzone = Induzone.query.filter_by(id=id).first()
data = {
"name": induzone.name, # 名称 "name": induzone.name, # 名称
"district": induzone.district, # 所属地区 # "district": induzone.district, # 所属地区
"phone": induzone.phone, # 电话 "phone": induzone.phone, # 电话
"email": induzone.email, "email": induzone.email,
"address": induzone.address, # 园区地址 # "address": induzone.address, # 园区地址
"industry_position": induzone.industry_position, # 产业定位 "industry_position": induzone.industry_position, # 产业定位
"cate": induzone.cate, # 园区类型 # "cate": induzone.cate, # 园区类型
"gdp": induzone.gdp, # GDP "gdp": induzone.gdp, # GDP
"represent": induzone.represent, # 代表企业 "represent": induzone.represent, # 代表企业
"introduct": induzone.introduct, # 简介 "introduct": induzone.introduct, # 简介
...@@ -570,7 +568,7 @@ def get_zaiti_detail_data(): ...@@ -570,7 +568,7 @@ def get_zaiti_detail_data():
"charge": induzone.charge, # 园区负责人 "charge": induzone.charge, # 园区负责人
"site": induzone.site, # 园区所在地 "site": induzone.site, # 园区所在地
"industry_type": induzone.industry_type, # 产业类型 "industry_type": induzone.industry_type, # 产业类型
"area": induzone.area, # 面积 # "area": induzone.area, # 面积
"out_power": induzone.out_power, # 产出强度（万元/亩） "out_power": induzone.out_power, # 产出强度（万元/亩）
"invest_power": induzone.invest_power, # 亩均投资强度（万元/亩） "invest_power": induzone.invest_power, # 亩均投资强度（万元/亩）
...@@ -589,7 +587,7 @@ def get_zaiti_detail_data(): ...@@ -589,7 +587,7 @@ def get_zaiti_detail_data():
"medical": induzone.medical, # 医疗机构 "medical": induzone.medical, # 医疗机构
"education": induzone.education, # 教育教育 "education": induzone.education, # 教育教育
} }
return jsonify(code=RET.OK, msg='园区详情查询成功！', data=data) return jsonify(code=RET.OK, msg='详情数据查询成功！', data=data)
except Exception as e: except Exception as e:
current_app.logger.error(e) current_app.logger.error(e)
......
apps/models.py
...@@ -188,8 +188,8 @@ class CompanyAdminPermission(db.Model): ...@@ -188,8 +188,8 @@ class CompanyAdminPermission(db.Model):
company_id = db.Column(db.Integer, doc='晋城企业id', comment='晋城企业id') company_id = db.Column(db.Integer, doc='晋城企业id', comment='晋城企业id')
number = db.Column(db.String(32), doc='晋城企业行政许可编号', comment='晋城企业行政许可编号') number = db.Column(db.String(32), doc='晋城企业行政许可编号', comment='晋城企业行政许可编号')
name = db.Column(db.String(32), doc='晋城企业行政许可证名称', comment='晋城企业行政许可证名称') name = db.Column(db.String(32), doc='晋城企业行政许可证名称', comment='晋城企业行政许可证名称')
time = db.Column(db.String(32), doc='许可证名称', comment='许可证名称') time = db.Column(db.DateTime, doc='有效期自', comment='有效期自')
effective_data = db.Column(db.String(32), doc='有效日期', comment='有效日期') effective_data = db.Column(db.DateTime, doc='有效期至', comment='有效期至')
Licensing_authority = db.Column(db.String(32), doc='许可机关', comment='许可机关') Licensing_authority = db.Column(db.String(32), doc='许可机关', comment='许可机关')
content = db.Column(db.String(32), doc='许可内容', comment='许可内容') content = db.Column(db.String(32), doc='许可内容', comment='许可内容')
source = db.Column(db.String(32), doc='来源', comment='来源') source = db.Column(db.String(32), doc='来源', comment='来源')
...@@ -215,7 +215,7 @@ class CompanyImportExport(db.Model): ...@@ -215,7 +215,7 @@ class CompanyImportExport(db.Model):
company_id = db.Column(db.Integer, doc='晋城企业id', comment='晋城企业id') company_id = db.Column(db.Integer, doc='晋城企业id', comment='晋城企业id')
register_customs = db.Column(db.String(32), doc='注册海关', comment='注册海关') register_customs = db.Column(db.String(32), doc='注册海关', comment='注册海关')
business_category = db.Column(db.String(32), doc='经营类别', comment='经营类别') business_category = db.Column(db.String(32), doc='经营类别', comment='经营类别')
register_date = db.Column(db.String(32), doc='注册日期', comment='注册日期') register_date = db.Column(db.DateTime, doc='注册日期', comment='注册日期')
# 晋城企业供应商 # 晋城企业供应商
...@@ -227,9 +227,11 @@ class CompanySupplier(db.Model): ...@@ -227,9 +227,11 @@ class CompanySupplier(db.Model):
supplier_name = db.Column(db.String(32), doc='客户名字', comment='客户名字') supplier_name = db.Column(db.String(32), doc='客户名字', comment='客户名字')
buy_rate = db.Column(db.String(32), doc='采购占比', comment='采购占比') buy_rate = db.Column(db.String(32), doc='采购占比', comment='采购占比')
buy_money = db.Column(db.String(32), doc='采购金额', comment='采购金额') buy_money = db.Column(db.String(32), doc='采购金额', comment='采购金额')
open_time = db.Column(db.String(32), doc='公开时间', comment='公开时间') open_time = db.Column(db.DateTime, doc='公开时间', comment='公开时间')
data_source = db.Column(db.String(32), doc='数据来源', comment='数据来源') data_source = db.Column(db.String(32), doc='数据来源', comment='数据来源')
relation = db.Column(db.String(32), doc='关联关系', comment='关联关系') relation = db.Column(db.String(32), doc='关联关系', comment='关联关系')
lng = db.Column(db.String(100), doc='经度', comment='经度') # 经度
lat = db.Column(db.String(100), doc='纬度', comment='纬度') # 纬度
# 晋城企业客户 # 晋城企业客户
...@@ -241,7 +243,7 @@ class CompanyCustomer(db.Model): ...@@ -241,7 +243,7 @@ class CompanyCustomer(db.Model):
customer_name = db.Column(db.String(32), doc='客户', comment='客户') customer_name = db.Column(db.String(32), doc='客户', comment='客户')
sales_rate = db.Column(db.String(32), doc='销售占比', comment='销售占比') sales_rate = db.Column(db.String(32), doc='销售占比', comment='销售占比')
sales_money = db.Column(db.String(32), doc='销售金额', comment='销售金额') sales_money = db.Column(db.String(32), doc='销售金额', comment='销售金额')
open_time = db.Column(db.String(32), doc='公开时间', comment='公开时间') open_time = db.Column(db.DateTime, comment='公开时间')
data_source = db.Column(db.String(32), doc='数据来源', comment='数据来源') data_source = db.Column(db.String(32), doc='数据来源', comment='数据来源')
relation = db.Column(db.String(32), doc='关联关系', comment='关联关系') relation = db.Column(db.String(32), doc='关联关系', comment='关联关系')
...@@ -258,7 +260,7 @@ class CompanyStock(db.Model): ...@@ -258,7 +260,7 @@ class CompanyStock(db.Model):
from_company = db.Column(db.String(25), doc='出质股权的企业', comment='出质股权的企业') from_company = db.Column(db.String(25), doc='出质股权的企业', comment='出质股权的企业')
pledgee = db.Column(db.String(10), doc='质权人', comment='质权人') pledgee = db.Column(db.String(10), doc='质权人', comment='质权人')
amount = db.Column(db.Float, doc='出质股权数额（万元）', comment='出质股权数额（万元）') amount = db.Column(db.Float, doc='出质股权数额（万元）', comment='出质股权数额（万元）')
datatime = db.Column(db.String(20), doc='登记日期', comment='登记日期') datatime = db.Column(db.DateTime, doc='登记日期', comment='登记日期')
status = db.Column(db.String(10), doc='状态', comment='状态') status = db.Column(db.String(10), doc='状态', comment='状态')
...@@ -275,7 +277,7 @@ class CompanyPledge(db.Model): ...@@ -275,7 +277,7 @@ class CompanyPledge(db.Model):
number = db.Column(db.Float, doc='质押股份总额（股）', comment='质押股份总额（股）') number = db.Column(db.Float, doc='质押股份总额（股）', comment='质押股份总额（股）')
amount = db.Column(db.Float, doc='质押股份市值（元）', comment='质押股份市值（元）') amount = db.Column(db.Float, doc='质押股份市值（元）', comment='质押股份市值（元）')
status = db.Column(db.String(10), doc='状态', comment='状态') status = db.Column(db.String(10), doc='状态', comment='状态')
datatime = db.Column(db.String(20), doc='公告日期', comment='公告日期') datatime = db.Column(db.DateTime, doc='公告日期', comment='公告日期')
# 晋城企业详情担保信息 # 晋城企业详情担保信息
...@@ -289,7 +291,7 @@ class CompanyDanbao(db.Model): ...@@ -289,7 +291,7 @@ class CompanyDanbao(db.Model):
person2 = db.Column(db.String(10), doc='担保方', comment='担保方') person2 = db.Column(db.String(10), doc='担保方', comment='担保方')
method = db.Column(db.String(10), doc='方式', comment='方式') method = db.Column(db.String(10), doc='方式', comment='方式')
amount = db.Column(db.Float, doc='担保金额（万元）', comment='担保金额（万元）') amount = db.Column(db.Float, doc='担保金额（万元）', comment='担保金额（万元）')
datatime = db.Column(db.String(20), doc='公告日期', comment='公告日期') datatime = db.Column(db.DateTime, doc='公告日期', comment='公告日期')
# 晋城企业详情专利信息 # 晋城企业详情专利信息
...@@ -303,9 +305,9 @@ class CompanyPatent(db.Model): ...@@ -303,9 +305,9 @@ class CompanyPatent(db.Model):
type = db.Column(db.String(20), doc='类型', comment='类型') type = db.Column(db.String(20), doc='类型', comment='类型')
status = db.Column(db.String(20), doc='法律状态', comment='法律状态') status = db.Column(db.String(20), doc='法律状态', comment='法律状态')
num = db.Column(db.String(50), doc='申请号', comment='申请号') num = db.Column(db.String(50), doc='申请号', comment='申请号')
day = db.Column(db.String(20), doc='申请日', comment='申请日') day = db.Column(db.DateTime, doc='申请日', comment='申请日')
open_num = db.Column(db.String(20), doc='公开号', comment='公开号') open_num = db.Column(db.String(20), doc='公开号', comment='公开号')
datatime = db.Column(db.String(20), doc='公开日期', comment='公开日期') datatime = db.Column(db.DateTime, doc='公开日期', comment='公开日期')
person = db.Column(db.String(20), doc='发明人', comment='发明人') person = db.Column(db.String(20), doc='发明人', comment='发明人')
......
apps/view_attract/view.py
import json import json
import os
import sys
from aliyunsdkcore.client import AcsClient from aliyunsdkcore.client import AcsClient
from aliyunsdkcore.acs_exception.exceptions import ClientException from aliyunsdkcore.acs_exception.exceptions import ClientException
from aliyunsdkcore.acs_exception.exceptions import ServerException from aliyunsdkcore.acs_exception.exceptions import ServerException
...@@ -37,7 +40,6 @@ def get_jjzb(district): ...@@ -37,7 +40,6 @@ def get_jjzb(district):
return jsonify(code=RET.DBERR, msg="数据库错误") return jsonify(code=RET.DBERR, msg="数据库错误")
@api_attract.route("/index", methods=["GET"]) @api_attract.route("/index", methods=["GET"])
def index(): def index():
return '德旭，你好！' return '德旭，你好！'
...@@ -155,7 +157,7 @@ def project(): ...@@ -155,7 +157,7 @@ def project():
project_map = [] project_map = []
industry_money = [] industry_money = []
industry_nums = [] industry_nums = []
list1 = ["晋城市", "沁水县", "高平市", "陵川县", "阳城县", "泽州县", "城区","晋城经济技术开发区"] list1 = ["晋城市", "沁水县", "高平市", "陵川县", "阳城县", "泽州县", "城区", "晋城经济技术开发区"]
# 晋城市，点击区县之前默认数据 # 晋城市，点击区县之前默认数据
if not district or district == '晋城市': if not district or district == '晋城市':
...@@ -470,16 +472,37 @@ def enterprise_detail(): ...@@ -470,16 +472,37 @@ def enterprise_detail():
''' '''
req_dict = request.get_json() req_dict = request.get_json()
_id = req_dict.get("id") # 企业id id = req_dict.get("id") # 企业id
# 校验参数完整性 # 校验参数完整性
if not all([_id]): if not all([id]):
return jsonify(code=RET.PARAMERR, msg="参数不完整") return jsonify(code=RET.PARAMERR, msg="参数不完整")
try: try:
company = Company.query.get(_id) company = Company.query.get(id)
# 工商状况-查询行政许可数据
data_info1 = CompanyAdminPermission.query.filter_by(company_id=id).all()
# 工商状况-查询税务信用数据
data_info2 = CompanyTaxCredit.query.filter_by(company_id=id).all()
# 工商状况-查询进出口信用数据
data_info3 = CompanyImportExport.query.filter_by(company_id=id).all()
# 工商状况-查询供应商数据信息
data_info4 = CompanySupplier.query.filter_by(company_id=id).all()
# 工商状况-查询客户数据信息
data_info5 = CompanyCustomer.query.filter_by(company_id=id).all()
# 企业风险-查询股权出质数据信息
data_info6 = CompanyStock.query.filter_by(company_id=id).all()
# 企业风险-查询股权质押数据信息
data_info7 = CompanyPledge.query.filter_by(company_id=id).all()
# 企业风险-查询担保信息数据信息
data_info8 = CompanyDanbao.query.filter_by(company_id=id).all()
# 知识产权-查询专利信息数据信息
data_info9 = CompanyPatent.query.filter_by(company_id=id).all()
# 供应链图谱数据
# 供应链地图
supplier = CompanySupplier.query.filter_by(company_id=id).all()
if company: if company:
data = {"id": company.id, data = {"select1_info": {"id": company.id,
"company_name": company.company_name, # 企业名 "company_name": company.company_name, # 企业名
"telephone": company.telephone if company.telephone else "-", # 电话 "telephone": company.telephone if company.telephone else "-", # 电话
"web_site": company.web_site if company.web_site else "-", # 网址 "web_site": company.web_site if company.web_site else "-", # 网址
...@@ -488,7 +511,8 @@ def enterprise_detail(): ...@@ -488,7 +511,8 @@ def enterprise_detail():
"jwd": {"lng": company.lng if company.lng else "-", # 经度 "jwd": {"lng": company.lng if company.lng else "-", # 经度
"lat": company.lat if company.lat else "-"}, # 维度 "lat": company.lat if company.lat else "-"}, # 维度
"company_info": company.company_info if company.company_info else "-", # 企业信息 "company_info": company.company_info if company.company_info else "-", # 企业信息
"business_scope": company.business_scope if company.business_scope else "-", # 经营范围 "business_scope": company.business_scope if company.business_scope else "-",
# 经营范围
"high_new": "高新技术企业" if company.high_new else "-", # 高新技术企业 "high_new": "高新技术企业" if company.high_new else "-", # 高新技术企业
"legal": company.legal if company.legal else "-", # 法定代表人 "legal": company.legal if company.legal else "-", # 法定代表人
"status": company.status if company.status else "-", # 状态 "status": company.status if company.status else "-", # 状态
...@@ -496,7 +520,7 @@ def enterprise_detail(): ...@@ -496,7 +520,7 @@ def enterprise_detail():
"capital": company.capital if company.capital else "-", # 注册资本 "capital": company.capital if company.capital else "-", # 注册资本
"social_code": company.social_code if company.social_code else "-", # 统一社会信用代码 "social_code": company.social_code if company.social_code else "-", # 统一社会信用代码
# "taking": company.takingn if company.takingn else "-", # 营收 (万元) # "taking": company.takingn if company.takingn else "-", # 营收 (万元)
"bao": company.bao_num if company.bao_num else "-", #参保人数 "bao": company.bao_num if company.bao_num else "-", # 参保人数
"entype": company.entype if company.entype else "-", # 企业类型 "entype": company.entype if company.entype else "-", # 企业类型
"industry": company.company_industry if company.company_industry else "-", # 所属行业 "industry": company.company_industry if company.company_industry else "-", # 所属行业
"scope": company.business_scope if company.business_scope else "-", # 企业经营范围 "scope": company.business_scope if company.business_scope else "-", # 企业经营范围
...@@ -504,10 +528,113 @@ def enterprise_detail(): ...@@ -504,10 +528,113 @@ def enterprise_detail():
# "choice": "3" # "choice": "3"
"tax_code": company.tax_code if company.tax_code else "-", "tax_code": company.tax_code if company.tax_code else "-",
"register_code": company.register_code if company.register_code else "-", "register_code": company.register_code if company.register_code else "-",
},
# 经营状况数据封装
"select2_info": {
"select2_info_name": '经营状况数据',
"label1": [{
"label1_name": '行政许可',
"number": data.number,
"name": data.name,
"time": (data.time).strftime("%Y-%m-%d %H:%M:%S"),
"effective_data": (data.effective_data).strftime("%Y-%m-%d %H:%M:%S"),
"Licensing_authority": data.Licensing_authority,
"content": data.content,
"source": data.source} for data in data_info1 if data_info1],
"label2": [{
"label2_name": '税务信用',
"evaluation_annual": data.evaluation_annual,
"identify_number": data.identify_number,
"level": data.level,
"evaluate": data.evaluate} for data in data_info2 if data_info2],
"label3": [{
"label3_name": '进出口信用',
"register_customs": data.register_customs,
"business_category": data.business_category,
"register_date": (data.register_date).strftime("%Y-%m-%d %H:%M:%S")} for data in data_info3 if data_info3],
"label4": [{
"label4_name": '供应商',
"supplier_name": data.supplier_name,
"buy_rate": data.buy_rate,
"buy_money": data.buy_money,
"open_time": (data.open_time).strftime("%Y-%m-%d %H:%M:%S"),
"data_source": data.data_source,
"relation": data.relation} for data in data_info4 if data_info4],
"label5": [{
"label5_name": '客户',
"customer_name": data.customer_name,
"sales_rate": data.sales_rate,
"sales_money": data.sales_money,
"open_time": (data.open_time).strftime("%Y-%m-%d %H:%M:%S"),
"data_source": data.data_source,
"relation": data.relation} for data in data_info5 if data_info5]
},
# 企业风险数据封装
"select3_info": {
"select3_info_name":'企业风险数据',
"label1": [{
"label1_name": '股权出质',
"num": data.num,
"person": data.person,
"from_company": data.from_company,
"pledgee": data.pledgee,
"amount": data.amount,
"datatime": (data.datatime).strftime("%Y-%m-%d %H:%M:%S"),
"status": data.status
} for data in data_info6 if data_info6],
"label2": [{
"label2_name": '股权质押',
"person1": data.person1,
"jion_company": data.jion_company,
"person2": data.person2,
"number": data.number,
"amount": data.amount,
"status": data.status,
"datatime": (data.datatime).strftime("%Y-%m-%d %H:%M:%S")
} for data in data_info7 if data_info7],
"label3": [{
"label3_name": '担保信息',
"person1": data.person1,
"person2": data.person2,
"method": data.method,
"amount": data.amount,
"datatime": (data.datatime).strftime("%Y-%m-%d %H:%M:%S")
} for data in data_info8 if data_info8]
},
# 知识产权数据封装
"select4_info": {
"select4_info_name":'专利信息',
"label": [{
"label_name": '专利信息',
"name": data.name,
"type": data.type,
"status": data.status,
"num": data.num,
"day": (data.day).strftime("%Y-%m-%d %H:%M:%S"),
"open_num": data.open_num,
"datatime": (data.datatime).strftime("%Y-%m-%d %H:%M:%S"),
"person": data.person
} for data in data_info9 if data_info9]
},
# 供应链图谱数据封装
"select5_info": {
},
# 供应链地图封装
"select6_info": {
"company_data": {"company_name": company.company_name,
"company_lat": company.lat,
"company_lng": company.lng,
"supplier": [{"supplier_name": i.supplier_name, 'lat': i.lat, 'lng': i.lng}
for i in supplier]}
}
} }
else: else:
return jsonify(code=RET.NODATA, msg="查无数据") return jsonify(code=RET.NODATA, msg="查无数据")
except Exception as e: except Exception as e:
exc_type, exc_obj, exc_tb = sys.exc_info()
fname = os.path.split(exc_tb.tb_frame.f_code.co_filename)[1]
print(exc_type, fname, exc_tb.tb_lineno)
current_app.logger.error(e) current_app.logger.error(e)
return jsonify(code=RET.DBERR, msg="数据库查询错误") return jsonify(code=RET.DBERR, msg="数据库查询错误")
return jsonify(code=RET.OK, msg="获取成功", data=data) return jsonify(code=RET.OK, msg="获取成功", data=data)
......
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