Skip to content

M
mancheng
Commit 2202041e by 赵宇
Options

fix

parent d58a9e55
Showing with 397 additions and 17 deletions
apps/models.py
......@@ -62,6 +62,10 @@ class Enterprise(db.Model):
high_new = db.Column(db.String(32), doc='是否高新技术企业', comment='是否高新技术企业') # 是否高新技术企业
parti_year = db.Column(db.Integer, doc='高新企业注册年份', comment='高新企业注册年份') # 高新企业注册年份
tbe = db.Column(db.String(32), doc='是否科技型中小企业', comment='是否科技型中小企业') # 是否科技型中小企业
tbe_sjmy = db.Column(db.String(32), doc='是否为省级民营科技企业', comment='是否为省级民营科技企业') # 省级民营科技企业
zjtg = db.Column(db.String(32), doc='是否为专精特新企业', comment='是否为专精特新企业') # 山西专精特工企业
zjtg_gjjxjr = db.Column(db.String(32), doc='是否为国家级专精特新小巨人企业', comment='是否为国家级专精特新小巨人企业') # 国家级专精特新小巨人企业
zjtg_sjxjr = db.Column(db.String(32), doc='是否为省级专精特新小巨人企业', comment='是否为省级专精特新小巨人企业') # 省级专精特新小巨人企业
fianacing = db.Column(db.String(32), doc='是否为有融资企业', comment='是否为有融资企业') # 是否为有融资企业
fianacing_rounds = db.Column(db.String(32), doc='融资轮次', comment='融资轮次') # 融资轮次
roundid = db.Column(db.Integer, index=True, doc='融资轮次id(天使/种子，1)（PreA/A+,2）（PreB/B+,3）(C轮以上，4)（收并购，5）（战略投资，6）（其他，7）', comment='融资轮次id(天使/种子，1)（PreA/A+,2）（PreB/B+,3）(C轮以上，4)（收并购，5）（战略投资，6）（其他，7）') # 融资轮次id(天使/种子，1)（PreA/A+,2）（PreB/B+,3）(C轮以上，4)（收并购，5）（战略投资，6）（其他，7）
......@@ -135,6 +139,7 @@ class Company(db.Model):
high_new = db.Column(db.String(32), doc='是否高新技术企业', comment='是否高新技术企业') # 是否高新技术企业
parti_year = db.Column(db.Integer, doc='高新企业注册年份', comment='高新企业注册年份') # 高新企业注册年份
tbe = db.Column(db.String(32), doc='是否科技型中小企业', comment='是否科技型中小企业') # 是否科技型中小企业
tbe_sjmy = db.Column(db.String(32), doc='是否为省级民营科技企业', comment='是否为省级民营科技企业') # 省级民营科技企业
fianacing = db.Column(db.String(32), doc='是否为有融资企业', comment='是否为有融资企业') # 是否为有融资企业
fianacing_rounds = db.Column(db.String(32), doc='融资轮次', comment='融资轮次') # 融资轮次
roundid = db.Column(db.Integer, doc='融资轮次id(天使/种子，1)（PreA/A+,2）（PreB/B+,3）(C轮以上，4)（收并购，5）（战略投资，6）（其他，7）', comment='融资轮次id(天使/种子，1)（PreA/A+,2）（PreB/B+,3）(C轮以上，4)（收并购，5）（战略投资，6）（其他，7）') # 融资轮次id(天使/种子，1)（PreA/A+,2）（PreB/B+,3）(C轮以上，4)（收并购，5）（战略投资，6）（其他，7）
......@@ -152,7 +157,9 @@ class Company(db.Model):
company_info = db.Column(db.Text, doc='公司简介', comment='公司简介') # 公司简介
sxmon = db.Column(db.String(32), doc='是否山西民营100强', comment='是否山西民营100强') # 是否山西民营100强（2019年）
zjtg = db.Column(db.String(32), doc='山西专精特工企业', comment='山西专精特工企业') # 山西专精特工企业
zjtg = db.Column(db.String(32), doc='是否为山西专精特新企业', comment='是否为山西专精特新企业') # 山西专精特工企业
zjtg_gjjxjr = db.Column(db.String(32), doc='是否为国家级专精特新小巨人企业', comment='是否为国家级专精特新小巨人企业') # 国家级专精特新小巨人企业
zjtg_sjxjr = db.Column(db.String(32), doc='是否为省级专精特新小巨人企业', comment='是否为省级专精特新小巨人企业') # 省级专精特新小巨人企业
unicorn = db.Column(db.String(32), doc='独角兽企业', comment='独角兽企业') # 独角兽企业
dengl = db.Column(db.String(32), doc='瞪羚', comment='瞪羚') # 瞪羚
hncode = db.Column(db.String(32), doc='高企证书编号', comment='高企证书编号') # 高企证书编号
......@@ -310,6 +317,137 @@ class CompanyPatent(db.Model):
person = db.Column(db.String(20), doc='发明人', comment='发明人')
# 全国企业表企业行政许可
class EnterpriseAdminPermission(db.Model):
__tablename_ = "company_admin_permission"
__table_args__ = ({'comment': '全国企业表企业行政许可数据表'}) # 添加表注释
id = db.Column(db.Integer, primary_key=True, autoincrement=True, doc='全国企业表企业行政许可主键id', comment='全国企业表企业行政许可主键id') # 企业
company_id = db.Column(db.Integer, doc='全国企业表企业id', comment='全国企业表企业id')
number = db.Column(db.String(32), doc='全国企业表企业行政许可编号', comment='全国企业表企业行政许可编号')
name = db.Column(db.String(32), doc='全国企业表企业行政许可证名称', comment='全国企业表企业行政许可证名称')
time = db.Column(db.DateTime, doc='有效期自', comment='有效期自')
effective_data = db.Column(db.DateTime, doc='有效期至', comment='有效期至')
Licensing_authority = db.Column(db.String(32), doc='许可机关', comment='许可机关')
content = db.Column(db.String(32), doc='许可内容', comment='许可内容')
source = db.Column(db.String(32), doc='来源', comment='来源')
# 全国企业表企业税务信用
class EnterpriseTaxCredit(db.Model):
__tablename_ = "company_tax_credit"
__table_args__ = ({'comment': '全国企业表企业税务信用数据表'}) # 添加表注释
id = db.Column(db.Integer, primary_key=True, autoincrement=True, doc='全国企业表企业税务信用主键id', comment='全国企业表企业税务信用主键id') # 企业
company_id = db.Column(db.Integer, doc='全国企业表企业id', comment='全国企业表企业id')
evaluation_annual = db.Column(db.String(32), doc='评价年度', comment='评价年度')
identify_number = db.Column(db.String(32), doc='纳税人识别号', comment='纳税人识别号')
level = db.Column(db.String(32), doc='纳税信用等级', comment='纳税信用等级')
evaluate = db.Column(db.String(32), doc='单位评价', comment='单位评价')
# 全国企业表企业进出口信用
class EnterpriseImportExport(db.Model):
__tablename_ = "company_import_export"
__table_args__ = ({'comment': '全国企业表企业进出口信用数据表'}) # 添加表注释
id = db.Column(db.Integer, primary_key=True, autoincrement=True, doc='全国企业表企业进出口信用主键id', comment='全国企业表企业进出口信用主键id') # 企业
company_id = db.Column(db.Integer, doc='全国企业表企业id', comment='全国企业表企业id')
register_customs = db.Column(db.String(32), doc='注册海关', comment='注册海关')
business_category = db.Column(db.String(32), doc='经营类别', comment='经营类别')
register_date = db.Column(db.DateTime, doc='注册日期', comment='注册日期')
# 全国企业表企业供应商
class EnterpriseSupplier(db.Model):
__tablename_ = "company_supplier"
__table_args__ = ({'comment': '全国企业表企业供应商数据表'}) # 添加表注释
id = db.Column(db.Integer, primary_key=True, autoincrement=True, doc='全国企业表企业供应商主键id', comment='全国企业表企业供应商主键id') # 企业
company_id = db.Column(db.Integer, doc='全国企业表企业id', comment='全国企业表企业id')
supplier_name = 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='采购金额')
open_time = db.Column(db.DateTime, doc='公开时间', comment='公开时间')
data_source = 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='纬度') # 纬度
# 全国企业表企业客户
class EnterpriseCustomer(db.Model):
__tablename_ = "company_customer"
__table_args__ = ({'comment': '全国企业表企业客户数据表'}) # 添加表注释
id = db.Column(db.Integer, primary_key=True, autoincrement=True, doc='全国企业表企业客户主键id', comment='全国企业表企业客户主键id') # 企业
company_id = db.Column(db.Integer, doc='全国企业表企业id', comment='全国企业表企业id')
customer_name = 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='销售金额')
open_time = db.Column(db.DateTime, comment='公开时间')
data_source = db.Column(db.String(32), doc='数据来源', comment='数据来源')
relation = db.Column(db.String(32), doc='关联关系', comment='关联关系')
# 全国企业表企业详情股权出质
class EnterpriseStock(db.Model):
__tablename_ = "company_stock"
__table_args__ = ({'comment': '全国企业表企业详情股权出质'}) # 添加表注释
id = db.Column(db.Integer, primary_key=True, autoincrement=True, doc='股权出质主键id', comment='股权出质主键id') # 企业
company_id = db.Column(db.Integer, doc='全国企业表企业id', comment='全国企业表企业id')
num = db.Column(db.String(32), doc='等级编号', comment='等级编号')
person = db.Column(db.String(10), doc='出质人', comment='出质人')
from_company = db.Column(db.String(25), doc='出质股权的企业', comment='出质股权的企业')
pledgee = db.Column(db.String(10), doc='质权人', comment='质权人')
amount = db.Column(db.Float, doc='出质股权数额（万元）', comment='出质股权数额（万元）')
datatime = db.Column(db.DateTime, doc='登记日期', comment='登记日期')
status = db.Column(db.String(10), doc='状态', comment='状态')
# 全国企业表企业详情股权质押
class EnterprisePledge(db.Model):
__tablename_ = "company_pledge"
__table_args__ = ({'comment': '全国企业表企业详情股权质押'}) # 添加表注释
id = db.Column(db.Integer, primary_key=True, autoincrement=True, doc='股权质押主键id', comment='股权质押主键id') # 企业
company_id = db.Column(db.Integer, doc='全国企业表企业id', comment='全国企业表企业id')
person1 = db.Column(db.String(10), doc='质押人', comment='质押人')
jion_company = db.Column(db.String(25), doc='参股企业', comment='参股企业')
person2 = db.Column(db.String(10), doc='质押权人', comment='质押权人')
number = db.Column(db.Float, doc='质押股份总额（股）', comment='质押股份总额（股）')
amount = db.Column(db.Float, doc='质押股份市值（元）', comment='质押股份市值（元）')
status = db.Column(db.String(10), doc='状态', comment='状态')
datatime = db.Column(db.DateTime, doc='公告日期', comment='公告日期')
# 全国企业表企业详情担保信息
class EnterpriseDanbao(db.Model):
__tablename_ = "company_pledge"
__table_args__ = ({'comment': '全国企业表企业详情担保信息'}) # 添加表注释
id = db.Column(db.Integer, primary_key=True, autoincrement=True, doc='担保信息主键id', comment='担保信息主键id') # 企业
company_id = db.Column(db.Integer, doc='全国企业表企业id', comment='全国企业表企业id')
person1 = db.Column(db.String(10), doc='被担保方', comment='被担保方')
person2 = db.Column(db.String(10), doc='担保方', comment='担保方')
method = db.Column(db.String(10), doc='方式', comment='方式')
amount = db.Column(db.Float, doc='担保金额（万元）', comment='担保金额（万元）')
datatime = db.Column(db.DateTime, doc='公告日期', comment='公告日期')
# 全国企业表企业详情专利信息
class EnterprisePatent(db.Model):
__tablename_ = "company_pledge"
__table_args__ = ({'comment': '全国企业表企业详情专利信息'}) # 添加表注释
id = db.Column(db.Integer, primary_key=True, autoincrement=True, doc='专利信息主键id', comment='专利信息主键id') # 企业
company_id = db.Column(db.Integer, doc='全国企业表企业id', comment='全国企业表企业id')
name = db.Column(db.String(50), doc='发明名称', comment='发明名称')
type = db.Column(db.String(20), doc='类型', comment='类型')
status = db.Column(db.String(20), doc='法律状态', comment='法律状态')
num = db.Column(db.String(50), doc='申请号', comment='申请号')
day = db.Column(db.DateTime, doc='申请日', comment='申请日')
open_num = db.Column(db.String(20), doc='公开号', comment='公开号')
datatime = db.Column(db.DateTime, doc='公开日期', comment='公开日期')
person = db.Column(db.String(20), doc='发明人', comment='发明人')
# 产业导航目录
class Industry(db.Model):
__tablename_ = "industry"
......
apps/view_360company/view.py
......@@ -9,6 +9,57 @@ from apps.utils.response_code import RET
from apps import redis_store
# 默认显示全国企业数据功能接口
@api_portraits.route('/GetAllEnterprise', methods=['POST'])
def get_all_enterprise():
'''
默认显示全国企业数据功能接口
:return:
'''
req_dict = request.get_json()
page = req_dict.get("page")
perpage = req_dict.get("perpage")
# 校验参数完整性
if not all([id]):
return jsonify(code=RET.PARAMERR, msg="参数不完整")
try:
enterprise_list = Enterprise.query.paginate(page, perpage).items
if enterprise_list:
data = [{"id": enterprise.id,
"company": enterprise.company_name, # 企业名
"area": enterprise.city + enterprise.district,
"createtime": enterprise.build_date,
"legal": enterprise.legal,
"capital": enterprise.capital,
"entype": enterprise.entype,
"address": enterprise.address,
"telephone": enterprise.telephone,
"fianacing": '融资企业' if enterprise.fianacing == "1" else '',
"quoted_company": '上市企业' if enterprise.quoted_company == "1" else '',
"high_new": '高新技术企业' if enterprise.high_new == '1' else "-",
"tbe": '科技型中小企业' if enterprise.tbe == '1' else "-",
"quoted_enterprise": '上市企业' if enterprise.quoted_company == '1' else "-",
"unicorn": '独角兽企业' if enterprise.unicorn == '1' else "-",
"dengl": '瞪羚' if enterprise.dengl == '1' else "-",
"isfive": '中国500强' if enterprise.isfive == '1' else "-",
"zjtg": '专精特新企业' if enterprise.zjtg == '1' else "-",
"zjtg_gjjxjr": '国家级专精特新小巨人企业' if enterprise.zjtg_gjjxjr == '1' else "-",
"zjtg_sjxjr": '省级专精特新小巨人企业' if enterprise.zjtg_sjxjr == '1' else "-",
"tbe_sjmy": '省级民营科技企业' if enterprise.tbe_sjmy == '1' else "-",
} for enterprise in enterprise_list]
else:
return jsonify(code=RET.NODATA, msg="查无数据")
except Exception as e:
current_app.logger.error(e)
return jsonify(code=RET.DBERR, msg="数据库查询错误")
return jsonify(code=RET.OK, msg="获取成功", data=data)
# 360企业画像--筛选条件下拉框
@api_portraits.route('/DropDownBox', methods=['GET'])
# @login_required
......@@ -310,7 +361,6 @@ def create_body(page, page_size, args_query, args_term):
print(body)
return body
# 原始
# def create_body(page, page_size, args_query, args_term):
# body = {
......
apps/view_atlas/view.py
......@@ -89,7 +89,7 @@ def get_cluster():
current_app.logger.error(e)
# 行业产品公司数量(链图,根据地理位置)
# 返回上中下游产业链数据接口
@api_atlas.route('/industry/chain', methods=['POST'])
# @login_required
def industry_chain():
......@@ -99,7 +99,6 @@ def industry_chain():
'''
req_dict = request.get_json()
inid = req_dict.get("inid") # 二级行业id（二级行业显示链图）
# district = req_dict.get("district") # 区县
# 校验参数完整性
if not all([inid]):
......
apps/view_index/view.py
......@@ -464,9 +464,9 @@ def showListb():
return jsonify(code=RET.DBERR, msg="数据库错误")
# 企业信息详情(招商驾驶舱左上角各类企业详情)
# 晋城企业信息详情(招商驾驶舱左上角各类企业详情)
@api_attract.route('/companyDetail', methods=['POST'])
def enterprise_detail():
def company_detail():
'''
企业信息详情
:return:
......@@ -530,15 +530,18 @@ def enterprise_detail():
"tax_code": company.tax_code if company.tax_code else "-",
"register_code": company.register_code if company.register_code else "-",
"high_new": '高新技术企业' if company.high_new == 1 else "-",
"tbe": '科技型中小企业' if company.tbe == 1 else "-",
# "fianacing": '融资企业' if company.fianacing == 1' else "-",
"quoted_company": '上市企业' if company.quoted_company == 1 else "-",
# "patent": '专利企业' if company.patent == 1' else "-",
"unicorn": '独角兽企业' if company.unicorn == 1 else "-",
"dengl": '瞪羚' if company.dengl == 1 else "-",
"isfive": '中国500强' if company.isfive == 1 else "-",
"zjtg": '中国500强' if company.zjtg == 1 else "-",
"high_new": '高新技术企业' if company.high_new == '1' else "-",
"tbe": '科技型中小企业' if company.tbe == '1' else "-",
# "fianacing": '融资企业' if company.fianacing == '1'' else "-",
"quoted_company": '上市企业' if company.quoted_company == '1' else "-",
# "patent": '专利企业' if company.patent == '1'' else "-",
"unicorn": '独角兽企业' if company.unicorn == '1' else "-",
"dengl": '瞪羚' if company.dengl == '1' else "-",
"isfive": '中国500强' if company.isfive == '1' else "-",
"zjtg": '山西专精特新企业' if company.zjtg == '1' else "-",
"zjtg_gjjxjr": '国家级专精特新小巨人企业' if company.zjtg_gjjxjr == '1' else "-",
"zjtg_sjxjr": '省级专精特新小巨人企业' if company.zjtg_sjxjr == '1' else "-",
"tbe_sjmy": '省级民营科技企业' if company.tbe_sjmy == '1' else "-",
},
# 经营状况数据封装
"select2_info": {
......@@ -650,6 +653,196 @@ def enterprise_detail():
return jsonify(code=RET.OK, msg="获取成功", data=data)
# 全国企业信息详情(招商雷达、产业招商地图、360企业画像用到的企业详情)
@api_attract.route('/EnterpriseDetail', methods=['POST'])
def enterprise_detail():
'''
企业信息详情
:return:
'''
req_dict = request.get_json()
id = req_dict.get("id") # 企业id
# 校验参数完整性
if not all([id]):
return jsonify(code=RET.PARAMERR, msg="参数不完整")
try:
enterprise = Enterprise.query.get(id)
# 工商状况-查询行政许可数据
data_info1 = EnterpriseAdminPermission.query.filter_by(company_id=id).all()
# 工商状况-查询税务信用数据
data_info2 = EnterpriseTaxCredit.query.filter_by(company_id=id).all()
# 工商状况-查询进出口信用数据
data_info3 = EnterpriseImportExport.query.filter_by(company_id=id).all()
# 工商状况-查询供应商数据信息
data_info4 = EnterpriseSupplier.query.filter_by(company_id=id).all()
# 工商状况-查询客户数据信息
data_info5 = EnterpriseCustomer.query.filter_by(company_id=id).all()
# 企业风险-查询股权出质数据信息
data_info6 = EnterpriseStock.query.filter_by(company_id=id).all()
# 企业风险-查询股权质押数据信息
data_info7 = EnterprisePledge.query.filter_by(company_id=id).all()
# 企业风险-查询担保信息数据信息
data_info8 = EnterpriseDanbao.query.filter_by(company_id=id).all()
# 知识产权-查询专利信息数据信息
data_info9 = EnterprisePatent.query.filter_by(company_id=id).all()
# 供应链图谱数据
# 供应链地图
supplier = EnterpriseSupplier.query.filter_by(company_id=id).all()
if enterprise:
data = {"select1_info": {"id": enterprise.id,
"enterprise_name": enterprise.company_name, # 企业名
"telephone": enterprise.telephone if enterprise.telephone else "-", # 电话
"web_site": enterprise.web_site if enterprise.web_site else "-", # 网址
"email": enterprise.email if enterprise.email else "-", # 邮箱
"address": enterprise.address if enterprise.address else "-", # 地址
"jwd": {"lng": enterprise.lng if enterprise.lng else "-", # 经度
"lat": enterprise.lat if enterprise.lat else "-"}, # 维度
"enterprise_info": enterprise.company_info if enterprise.company_info else "-", # 企业信息
"business_scope": enterprise.business_scope if enterprise.business_scope else "-",
# 经营范围
# "high_new": "高新技术企业" if enterprise.high_new else "-", # 高新技术企业
"legal": enterprise.legal if enterprise.legal else "-", # 法定代表人
"status": enterprise.status if enterprise.status else "-", # 状态
"build_date": str(enterprise.build_date)[:10] if enterprise.build_date else "-", # 创建时间
"capital": enterprise.capital if enterprise.capital else "-", # 注册资本
"social_code": enterprise.social_code if enterprise.social_code else "-", # 统一社会信用代码
# "taking": enterprise.takingn if enterprise.takingn else "-", # 营收 (万元)
"bao": enterprise.bao_num if enterprise.bao_num else "-", # 参保人数
"entype": enterprise.entype if enterprise.entype else "-", # 企业类型
"industry": enterprise.company_industry if enterprise.company_industry else "-", # 所属行业
"scope": enterprise.business_scope if enterprise.business_scope else "-", # 企业经营范围
# "collect": "1",
# "choice": "3"
"tax_code": enterprise.tax_code if enterprise.tax_code else "-",
"register_code": enterprise.register_code if enterprise.register_code else "-",
"high_new": '高新技术企业' if enterprise.high_new == '1' else "-",
"tbe": '科技型中小企业' if enterprise.tbe == '1' else "-",
# "fianacing": '融资企业' if enterprise.fianacing == '1'' else "-",
"quoted_enterprise": '上市企业' if enterprise.quoted_company == '1' else "-",
# "patent": '专利企业' if enterprise.patent == '1'' else "-",
"unicorn": '独角兽企业' if enterprise.unicorn == '1' else "-",
"dengl": '瞪羚' if enterprise.dengl == '1' else "-",
"isfive": '中国500强' if enterprise.isfive == '1' else "-",
"zjtg": '专精特新企业' if enterprise.zjtg == '1' else "-",
"zjtg_gjjxjr": '国家级专精特新小巨人企业' if enterprise.zjtg_gjjxjr == '1' else "-",
"zjtg_sjxjr": '省级专精特新小巨人企业' if enterprise.zjtg_sjxjr == '1' else "-",
"tbe_sjmy": '省级民营科技企业' if enterprise.tbe_sjmy == '1' 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": enterprise.company_name,
"company_lat": enterprise.lat,
"company_lng": enterprise.lng,
"supplier": [{"supplier_name": i.supplier_name, 'lat': i.lat, 'lng': i.lng}
for i in supplier]}
}
}
else:
return jsonify(code=RET.NODATA, msg="查无数据")
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)
return jsonify(code=RET.DBERR, msg="数据库查询错误")
return jsonify(code=RET.OK, msg="获取成功", data=data)
# # 删除缓存
# @api_attract.route("/deleteX", methods=["GET"])
# def deleteX():
......
apps/view_map/view.py
......@@ -79,7 +79,7 @@ def attract_map():
district_data = Enterprise.query.filter_by(province=province, city=city, district=dis).first()
df.append({"name": dis,
"value": num,
"color": jishu(num),
# "color": jishu(num),
"jwd": {"lng": district_data.d_lng, "lat": district_data.d_lat}})
return jsonify(code=RET.OK, msg="获取成功", data=df)
......@@ -90,7 +90,7 @@ def attract_map():
if district_data:
df.append({"name": district,
"value": num,
"color": "",
# "color": "",
"jwd": {"lng": district_data.d_lng, "lat": district_data.d_lat}})
return jsonify(code=RET.OK, msg="获取成功", data=df)
else:
......
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