='".$day_st."'"; if($day_end) $where .= " and trade_date <='".$day_end."'"; $sql= <<query($sql); $tDate=$idx=$data=array(); if($result && $result->num_rows>0) { #$data = $result->fetch_all(); while($row=$result->fetch_assoc()){ $trade_date=substr($row['trade_date'],0,4).'-'.substr($row['trade_date'],4,2).'-'.substr($row['trade_date'],6,2); $trade_date1=strtotime($row['trade_date']); array_push($tDate,$trade_date); array_push($idx,$row['close']); array_push($data,array("value"=>array($trade_date,round($row['close'],2)))); } } #Free result and close connection. $result->free(); $mysqli->close(); return array('tDate'=>$tDate,'idx'=>$idx,'data'=>$data); } /* #LX: 序号 1-6,分别代表基金，QFII, 社保，券商，保险，信托 #share: vposition 市值 f10, sahreHDnum 股数 f9 */ function getIhData($lx,$share,$day_st,$day_end){ $mysqli = new mysqli('localhost','root','nancysimon','myquant'); /* $where = " and rdate>='".$day_st."'"; if($day_end) $where .= " and rdate<='".$day_end."'"; if($share=='ShareHDNum' or $share=='vPosition') $shareSel='sum('.$share.')/100000000'; elseif($share=='VSRatio') $shareSel='vPosition/ShareHDNum'; $sql= <<query($sql); //echo $sql; $tDate=$idx=$data=array(); if($result && $result->num_rows>0) { #$data = $result->fetch_all(); while($row=$result->fetch_assoc()){ array_push($tDate,$row['ih_date']); array_push($idx,$row['ttl']); array_push($data,array("value"=>array($row['ih_date'],$row['ttl']))); } } #Free result and close connection. $result->free(); $mysqli->close(); return array('tDate'=>$tDate,'idx'=>$idx,'data'=>$data); } function lxDefine($lx){ switch($lx){ case 1: return "公募基金"; case 2: return "QFII"; case 3: return "社保基金"; case 4: return "券商持仓"; case 5: return "保险持仓"; case 6: return "信托持仓"; } } /* 上证指数：000001.SH 深证成指：399001.SZ 中小板指: 399005.SZ 创业板指：399006.SZ */ function codetocode($code){ switch($code){ case 'sh': return '000001.SH'; case 'sz': return '399001.SZ'; case 'zx': return '399005.SZ'; case 'cy': return '399006.SZ'; case 'all': return '000002.SH'; } } /** * @param $code * @return string|void */ function codeToName($code){ switch($code){ case 'sh': return '上证'; case 'sz': return '深证'; case 'zx': return '中小板'; case 'cy': return '创业板'; case 'all': return 'A股'; } } /** * 名称 类型 描述 trade_date str 交易日期 ggt_ss float 港股通（上海） ggt_sz float 港股通（深圳） hgt float 沪股通（百万元） sgt float 深股通（百万元） north_money float 北向资金（百万元） south_money float 南向资金（百万元） * @param $code * @return false|string */ function hsgtConv($code){ switch ($code){ case 'ggt_ss': return '港股通（上海）'; case 'ggt_sz': return '港股通（深圳）'; case 'hgt': return '沪股通'; case 'sgt': return '深股通'; case 'north_money': return '北向资金'; case 'south_money': return '南向资金'; default: return false; } } function hkholdConv($code){ switch ($code){ case 'ratio': return '持股比例(%)'; case 'vol': return '持股数(万)'; default: return false; } } /* #item: f9:持股数 f10:持股额 f11:占总股本比例 f12:占流通股比例 #LX: tp字段: 序号 1-6,分别代表基金，QFII, 社保，券商，保险，信托 */ function getIhDataByStock($ts_code,$item,$lx,$day_st,$day_end){ $mysqli = new mysqli('localhost','root','nancysimon','myquant'); $where = " and ih_date>'".$day_st."'"; if($day_end) $where .= " and ih_date<'".$day_end."'"; if($lx) $where .= " and tp='".$lx."'"; switch(strtoupper($item)){ case 'F9': $item_sel = 'sum('.$item.')/10000'; #单位万股 break; case 'F10': $item_sel = 'sum('.$item.')/10000'; #单位万元 break; case 'F11': case 'F12': $item_sel = 'sum('.$item.')'; #单位% break; } $sql= <<query($sql); #echo $sql; $tDate=$idx=$data=array(); if($result && $result->num_rows>0) { #$data = $result->fetch_all(); while($row=$result->fetch_assoc()){ array_push($tDate,$row['ih_date']); array_push($idx,$row['ttl']); array_push($data,array("value"=>array($row['ih_date'],$row['ttl']))); } } $data_last= round($idx[count($idx)-1],1); $data_max= round(max($idx),1); $data_min= round(min($idx),1); if(count($idx)>0) $data_avg= round(array_sum($idx)/count($idx),1); else $data_avg=null; #Free result and close connection. $result->free(); $mysqli->close(); return array('tDate'=>$tDate,'idx'=>$idx,'data'=>$data,'data_max'=>$data_max,'data_min'=>$data_min,'data_avg'=>$data_avg,'data_last'=>$data_last); } function getMoneyFlowData($itm, $day_st,$day_end, $stacked){ $mysqli = new mysqli('localhost','root','nancysimon','myquant'); if($stacked==1) $tb = 'moneyflow_hsgt_pro_ext'; else $tb = 'moneyflow_hsgt_pro'; $where = " trade_date>='".$day_st."'"; if($day_end) $where .= " and trade_date <='".$day_end."'"; $sql= <<query($sql); $tDate=$data=array(); if($result && $result->num_rows>0) { while($row=$result->fetch_assoc()){ $trade_date=date('Y-m-d',strtotime($row['trade_date'])); array_push($tDate,$row['itm']/100); array_push($data,array("value"=>array($trade_date,round($row['itm']/100,2)))); } } #Free result and close connection. $result->free(); $mysqli->close(); $data_last= round($tDate[count($tDate)-1],2); $data_max= round(max($tDate),2); $data_min= round(min($tDate),2); if(count($tDate)>0) $data_avg= round(array_sum($tDate)/count($tDate),2); return array('tDate'=>$tDate,'data'=>$data,'data_max'=>$data_max,'data_min'=>$data_min,'data_avg'=>$data_avg,'data_last'=>$data_last); } ?>