d

rpt_result/GetFIinfoFromJson.py

+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+# @Time    : 2020/2/11 19:43
+# @Author  : fanhui
+# @File    : GetFIinfoFromJson.py
+# @Software: PyCharm
+
+#变化率添加符号
+def AddSign(factor):
+    factor=factor
+    if "-" in factor and"%"in factor:
+        factor=factor.replace("-", "") + "↓"
+    elif "%"in factor and "-"not in factor:
+        factor = factor+"↑"
+    # print(factor)
+    return factor
+
+
+def GetFIinfoFromJson(GetAllinfo):
+# 获取传入的参数
+    GetAllinfo = GetAllinfo
+    Else_info={
+        "Detection_zone": GetAllinfo.get("Detection_zone",None),
+        "CreatTime": GetAllinfo.get("CreatTime",None),
+        "company_name": GetAllinfo.get("company_name",None),
+        "Task_Num": GetAllinfo.get("Task_Num",None)
+    }
+
+    FIinfo=GetAllinfo.get("fi",None)#如果key不存在，会返回None,因此需进行判断
+    Fi_dict={}
+    if FIinfo:
+        Total_trade_income=FIinfo[0].get("Total_trade_income",None)
+        Bq_time=''
+        Sq_time=''
+        if Total_trade_income:
+            print(eval(Total_trade_income),type(eval(Total_trade_income)))
+            keys_list = []
+            Total_trade_income=eval(Total_trade_income)#str转dict,用eval
+            for t_k,t_v in Total_trade_income.items():
+                keys_list.append(t_k)
+            Bq_time=keys_list[0]
+            Sq_time=keys_list[1]
+        Total_profit = eval(FIinfo[1].get("Total_profit"))
+        Net_profit = eval(FIinfo[2].get("Net_profit"))
+        Total_Liabilities = eval(FIinfo[3].get("Total_Liabilities"))
+        Owner_rights = eval(FIinfo[4].get("Owner_rights"))
+        Total_sales = eval(FIinfo[5].get("Total_sales"))
+        Total_assets = eval(FIinfo[6].get("Total_assets"))
+        Total_liabilities_and_Owner_rights = eval(FIinfo[7].get("Total_liabilities_and_Owner_rights"))
+        sales_expense=eval(FIinfo[8].get("sales_expense"))
+        Net_interest_rate = eval(FIinfo[9].get("Net_interest_rate"))
+        Equity_ratio = eval(FIinfo[10].get("Equity_ratio"))
+        Gearing_ratio = eval(FIinfo[11].get("Gearing_ratio"))
+        sales_growth_rate = eval(FIinfo[12].get("sales_growth_rate"))
+        Net_profit_growth_rate = eval(FIinfo[13].get("Net_profit_growth_rate"))
+        print(type(FIinfo[14].get("total_assets_growth_rate")),FIinfo[14].get("total_assets_growth_rate"))
+        total_assets_growth_rate = eval(FIinfo[14].get("total_assets_growth_rate"))
+        Fi_dict["Bq_time"] = Bq_time
+        Fi_dict["Sq_time"] = Sq_time
+        Fi_dict["Bq_Total_trade_income"]=Total_trade_income[Bq_time]
+        Fi_dict["Sq_Total_trade_income"] = Total_trade_income[Sq_time]
+        Fi_dict["change_rate_1"] = AddSign(Total_trade_income["change_rate"])
+        Fi_dict["Bq_Total_profit"]=Total_profit[Bq_time]
+        Fi_dict["Sq_Total_profit"]=Total_profit[Sq_time]
+        Fi_dict["change_rate_2"]=AddSign(Total_profit["change_rate"])
+        Fi_dict["Bq_Net_profit"]=Net_profit[Bq_time]
+        Fi_dict["Sq_Net_profit"]=Net_profit[Sq_time]
+        Fi_dict["change_rate_3"]=AddSign(Net_profit["change_rate"])
+        Fi_dict["Bq_Total_Liabilities"]=Total_Liabilities[Bq_time]
+        Fi_dict["Sq_Total_Liabilities"]=Total_Liabilities[Sq_time]
+        Fi_dict["change_rate_4"]=AddSign(Total_Liabilities["change_rate"])
+        Fi_dict["Bq_Owner_rights"]=Owner_rights[Bq_time]
+        Fi_dict["Sq_Owner_rights"]=Owner_rights[Sq_time]
+        Fi_dict["change_rate_5"]=AddSign(Owner_rights["change_rate"])
+        Fi_dict["Bq_Total_sales"]=Total_sales[Bq_time]
+        Fi_dict["Sq_Total_sales"]=Total_sales[Sq_time]
+        Fi_dict["change_rate_6"]=AddSign(Total_sales["change_rate"])
+        Fi_dict["Bq_Total_assets"]=Total_assets[Bq_time]
+        Fi_dict["Sq_Total_assets"]=Total_assets[Sq_time]
+        Fi_dict["change_rate_7"]=AddSign(Total_assets["change_rate"])
+        Fi_dict["Bq_Total_liabilities_and_Owner_rights"]=Total_liabilities_and_Owner_rights[Bq_time]
+        Fi_dict["Sq_Total_liabilities_and_Owner_rights"]=Total_liabilities_and_Owner_rights[Sq_time]
+        Fi_dict["Bq_sales_expense"] = sales_expense[Bq_time]
+        Fi_dict["Sq_sales_expense"] = sales_expense[Sq_time]
+        Fi_dict["Bq_Net_interest_rate"] = Net_interest_rate[Bq_time]
+        Fi_dict["Sq_Net_interest_rate"] = Net_interest_rate[Sq_time]
+        Fi_dict["Bq_Equity_ratio"] = Equity_ratio[Bq_time]
+        Fi_dict["Sq_Equity_ratio"] = Equity_ratio[Sq_time]
+        Fi_dict["Bq_Gearing_ratio"] = Gearing_ratio[Bq_time]
+        Fi_dict["Sq_Gearing_ratio"] = Gearing_ratio[Sq_time]
+        Fi_dict["Bq_sales_growth_rate"] = sales_growth_rate[Bq_time]
+        Fi_dict["Sq_sales_growth_rate"] = sales_growth_rate[Sq_time]
+        Fi_dict["Bq_Net_profit_growth_rate"] = Net_profit_growth_rate[Bq_time]
+        Fi_dict["Sq_Net_profit_growth_rate"] = Net_profit_growth_rate[Sq_time]
+        Fi_dict["Bq_total_assets_growth_rate"] = total_assets_growth_rate[Bq_time]
+        Fi_dict["Sq_total_assets_growth_rate"] = total_assets_growth_rate[Sq_time]
+    return Else_info,Fi_dict

rpt_result/getcompanyinfofromES.py

+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+# @Time    : 2020/2/11 19:25
+# @Author  : fanhui
+# @File    : getcompanyinfofromES.py
+# @Software: PyCharm
+
+import os, sys
+from flask_cors import *
+import json
+from flask import Flask
+import oss2,time,datetime
+from elasticsearch import Elasticsearch
+
+
+
+server = Flask(__name__)
+interface_path = os.path.dirname(__file__)
+sys.path.insert(0, interface_path)  # 将当前文件的父目录加入临时系统变量
+server.config['JSON_AS_ASCII'] = False
+CORS(server, supports_credentials=True)  # 跨域请求
+
+
+
+# 工商数据接口
+def GetComanyinfoFromES(companyname):
+    esip = "43.247.184.94"
+    esport = 9200
+    esuser = "admines"
+    espassword = "adminGSBes"
+    es = Elasticsearch([esip], http_auth=(esuser, espassword), port=esport, timeout=15000)
+    companyinfo = es.search(index="bigdata_ic_gsb_company_op",
+                            body={"query": {"bool": {"must": {"term": {"company_name.raw": companyname}}}}})
+    companylist = {}
+    if companyinfo["hits"]["hits"]:
+        for row in companyinfo["hits"]["hits"]:
+            companyname = row['_source']["company_name"]  # 公司名称
+            legal_person = row['_source']["legal_person"]  # 法定代表人
+            if legal_person is None:
+                legal_person = "_"
+            cred_code = row['_source']["credit_code"]  # 统一社会信用代码
+            if cred_code is None:
+                cred_code = "_"
+            gsb_province = row['_source']["base"]  # 所属省份
+            if gsb_province is None:
+                gsb_province = "_"
+            gsb_city = row['_source']["gsb_city"] #城市
+            if gsb_city is None:
+                gsb_city="_"
+            reg_location = row['_source']["reg_location"]  # 企业地址
+            if reg_location is None:
+                reg_location = "_"
+            establish_time = time.strftime("%Y-%m-%d", time.localtime(row["_source"]["estiblish_time"]))  # 成立日期
+            if establish_time is None:
+                establish_time = "_"
+            company_cate_1 = row['_source']["gsb_company_cate_1"]  # 所属行业
+            if company_cate_1 is None:
+                company_cate_1 = "_"
+            company_org_type = row['_source']["company_org_type"]  # 企业类型
+            if company_org_type is None:
+                company_org_type = "_"
+            reg_institute = row['_source']["reg_institute"]  # 登记机关
+            if reg_institute is None:
+                reg_institute = "_"
+            reg_status = row['_source']["reg_status"]  # 营业状态
+            if reg_status is None:
+                reg_status = "_"
+            reg_capital = row['_source']["reg_capital"]  # 注册资本
+            reg_unit=row['_source']["reg_unit"]  # 注册资本单位
+            if reg_capital is None:
+                reg_capital = "_"
+            else:
+                if reg_unit=="万人民币":
+                    reg_capital = str(reg_capital) + "万元"
+                else:
+                    reg_capital = str(reg_capital)
+            from_time = time.strftime("%Y-%m-%d", time.localtime(row["_source"]["from_time"]))  # 营业期限开始
+            if from_time is None:
+                from_time = "_"
+            to_time = time.strftime("%Y-%m-%d", time.localtime(row["_source"]["to_time"]))  # 营业期限结束
+            if to_time is None:
+                to_time = "_"
+            approved_time = time.strftime("%Y-%m-%d", time.localtime(row["_source"]["approved_time"]))  # 核准日期
+            if approved_time is None:
+                approved_time = "_"
+            business_scope = row['_source']["business_scope"]  # 经营范围
+            if business_scope is None:
+                business_scope = "_"
+            companylist["companyname"] = companyname
+            companylist["legal_person"] = legal_person
+            companylist["cred_code"] = cred_code
+            companylist["province"] = gsb_province
+            companylist["city"] = gsb_city
+            companylist["reg_location"] = reg_location
+            companylist["establish_time"] = establish_time
+            companylist["company_cate_1"] = company_cate_1
+            companylist["company_org_type"] = company_org_type
+            companylist["reg_institute"] = reg_institute
+            companylist["reg_capital"] = reg_capital
+            companylist["reg_status"] = reg_status
+            companylist["from_time"] = from_time
+            companylist["to_time"] = to_time
+            companylist["approved_time"] = approved_time
+            companylist["business_scope"] = business_scope
+        return companylist
+# a=GetComanyinfoFromES("用友网络科技股份有限公司")
+# print(a)
\ No newline at end of file