Appearance
business-common
business-common封装了业务处理、SQL操作、配置工具类，目前封装部分基金模块函数。
使用方法
在C:\Users\xxx目录下创建pip.conf文件，内容如下：
[global]
index-url=http://192.168.14.111:8082/repository/pypi-public/
[install]
trusted-host=192.168.14.111[global]
index-url=http://192.168.14.111:8082/repository/pypi-public/
[install]
trusted-host=192.168.14.111配置好环境安装模块
pip install business-common==1.0.0pip install business-common==1.0.0函数结构
📃 bus_func.py [业务数据处理]
📃 fund_sql.py [基金SQL处理]
📃 public_func.py [配置工具]
📃 SqlServer_Connect.py [数据库连接类]📃 bus_func.py [业务数据处理]
📃 fund_sql.py [基金SQL处理]
📃 public_func.py [配置工具]
📃 SqlServer_Connect.py [数据库连接类]函数说明
| 文件名 | 函数名 | 描述 |
|---|---|---|
| bus_func.py | into_db | 用于update or insert 基金评价相关的五张表 主键 sec_id pub_dt |
| get_ret_total | 得到基金的ret | |
| get_nav_total | 获取所有基金的净值，基于数据源所有基金拆分为货币基金和非货币基金 | |
| fetch_calendar | 获取中日交易日历，标准化日期返回list列表 | |
| check_trade_day | 检查是否为交易日，返回bool值 | |
| fetch_bm_returns | 确认市场基准：股票大盘、利率债、信用，获取市场基准的收益率，返回DataFrame对象 | |
| fetch_funds_list | 获取所有基金数据，返回list列表 | |
| historical_trading_day | 获取历史交易日信息 | |
| fill_na_for_nav_total_in_trade_day | nav_total_df 中间的交易日 以空值填充 | |
| fund_sql.py | bm_sql | 查询sid基准，输出交易日、sid、收盘价，返回DataFrame对象 |
| funs_sql | 获取所有基金的基本信息，根据is_run_history判断是否是历史数据，返回DataFrame对象 | |
| fetch_nav | 获取基金净值，返回DataFrame对象 | |
| calendar_sql | 查询中国交易日历，返回交易日历DataFrame对象 | |
| fetch_nt_val | 获取已经入库的净值(注意：数据库保留四位小数 此处要保持一致)，返回DataFrame对象 | |
| fetch_ret_mny | 获取货币型基金日收益，返回DataFrame对象 | |
| fetch_estab_dt | 查询所有基金成立日期，返回基金成立日期DataFrame对象 | |
| fetch_fmgr_sco | 获取某基金在某日的不同期限的基金经理得分 | |
| fetch_com_dt_hist | 获取公司自己定义的horizon，返回DataFrame | |
| fetch_bench_value | 得到最新的基准值 | |
| fetch_fund_category | 查询基金类型 | |
| fetch_com_dt_hist_df | 获取公司自己定义的horizon，返回DataFrame | |
| fetch_all_publish_sid | 获取所有当日披露净值的基金或者所有未退市的基金，根据is_run_history判断是否是历史数据，返回DataFrame对象 | |
| fetch_index_fund_bench_ret | 得到指数基金的基准ret，返回DataFrame对象 | |
| fetch_fund_performance_ret | 获取在交易日date所有基金的收益指标数据，返回DataFrame对象 | |
| fetch_fund_performance_vol | 获取在交易日date所有基金的波动率指标数据，返回DataFrame对象 | |
| fetch_fund_performance_comp | 获取在交易日date所有基金的综合业绩指标数据，返回DataFrame对象 | |
| fetch_fund_performance_other | 获取在交易日date所有基金的其他指标数据，返回DataFrame对象 | |
| fetch_fund_nav_up_time_in_given_time_period | 获取在给定时间段内基金净值更新时间，返回DataFrame对象 | |
| fetch_bench_ret_up_time_in_given_time_period | 更新时间在给定时间范围，主程序覆盖不到的更新 | |
| public_func.py | py_hdfs | hdfs连接 配置，返回HdfsClient对象 |
| read_sql | SQLServer连接引擎，传入SQL语句，返回DataFrame | |
| read_conf | 读取配置文件，返回配置信息 | |
| spark_mssql | SparkSQL连接配置，返回DataFrame | |
| SqlServer_Connect.py | getConnect | 连接数据库 |
| exeQuery | 执行查询 | |
| exeNonQuery | 执行非查询类语句 | |
| getConnectInfo | 获取连接信息 | |