'''
获取所有股票基本面数据
'''
# 引入掘金API
# todo  解决掘金api 数据 的引入问题
from gm.api import *
# 引入基础方法
import basic_methods
# 引入全局变量模块
import data_cache

# 调用推算前N日交易日期的函数
start_time_data = basic_methods.pre_num_trading_day(data_cache.DataCache().today_date, 90)
'''
股票交易衍生表
'''
# trading_derivative_indicator = get_fundamentals(table='trading_derivative_indicator', symbols='SHSE.601777', start_date=start_time_data, end_date=data_cache.today_date, fields='DY,EV,EVEBITDA,EVPS,LYDY,NEGOTIABLEMV,PB,PELFYNPAAEI,PETTMNPAAEI,TURNRATE', df=True)
# print(f"trading_derivative_indicator===\n{trading_derivative_indicator}")
trading_derivative_indicator_1 = get_fundamentals(table='trading_derivative_indicator', symbols='SZSE.000890', start_date=start_time_data, end_date=data_cache.DataCache().today_date, fields='NEGOTIABLEMV', df=False)
# print(f"trading_derivative_indicator_1===\n{trading_derivative_indicator_1[0]}")
for i in trading_derivative_indicator_1:
    # 流通市值
    circulation_market_value = round(i['NEGOTIABLEMV']/100000000, 2)
    print(f"流通市值{circulation_market_value} 亿  更新日期：{i['pub_date']}")

'''
衍生财务指标
'''
deriv_finance_indicator = get_fundamentals(table='deriv_finance_indicator', symbols='SZSE.000890', start_date=start_time_data, end_date=data_cache.DataCache().today_date, fields='FCFE, FCFF', df=False)
# print(f"deriv_finance_indicator===\n{deriv_finance_indicator[0]}")
for i in deriv_finance_indicator:

    shareholders_free_cash_flow = round(i['FCFF']/100000000, 2)  # 股东自由现金流量
    enterprise_free_cash_flow = round(i['FCFF']/100000000, 2)    # 企业自由现金流量
    print(f"股东自由现金流量{shareholders_free_cash_flow} 亿   企业自由现金流量{enterprise_free_cash_flow} 亿  更新日期：{i['pub_date']}")

# income_statement = get_fundamentals(table='income_statement', symbols='SHSE.601777', start_date=start_time_data, end_date=data_cache.today_date, fields='AVAIDISTSHAREPROF,BASICEPS,NETPROFIT,PERPROFIT', df=True)
# print(f"income_statement===\n{income_statement}")