import numpy as np
import pandas as pd
import pandas.io.sql as sql
import cx_Oracle as co
# <editor-fold desc="數(shù)據(jù)提取">
# 取用數(shù)據(jù)
dsn = co.makedsn('220.248.233.27', 1521, 'zywinddb')
conn = co.connect('wind', 'w1i2n3d4a5', dsn)
c = conn.cursor()
s_a = (
    """select  trade_dt,s_info_windcode,s_dq_adjclose 
    from ashareeodprices where trade_dt=20181228 order by s_info_windcode""")
s_b = (
    """select  trade_dt,s_info_windcode,s_dq_adjclose 
    from ashareeodprices where trade_dt=20190628 order by s_info_windcode""")
data_a = sql.read_sql(s_a, conn)
data_b = sql.read_sql(s_b, conn)
c.close()
conn.close()
# </editor-fold>
pl = []
for i in range(len(data_b)):
    try:
        loc = data_a[data_a.S_INFO_WINDCODE ==
                     data_b.S_INFO_WINDCODE[i]].index.tolist()[-1]
        pl.append(data_b.S_DQ_ADJCLOSE[i] / data_a.S_DQ_ADJCLOSE[loc] - 1)
    except BaseException:
        pass
    continue
pl = np.array(pl)
result = pd.DataFrame([{'項(xiàng)目': '內(nèi)容',
                        '平均數(shù)': np.mean(pl),
                        '中位數(shù)': np.median(pl),
                        '25%分位點(diǎn)': np.percentile(pl,
                                                75),
                        '股票數(shù)量': len(pl),
                        '正收益數(shù)量': sum(i > 0 for i in pl)}],
                      columns=['項(xiàng)目',
                               '平均數(shù)',
                               '中位數(shù)',
                               '25%分位點(diǎn)',
                               '股票數(shù)量',
                               '正收益數(shù)量'])