265 lines
7.7 KiB
PHP
265 lines
7.7 KiB
PHP
<?php
|
|
/**
|
|
* PHP发送Json对象数据
|
|
*
|
|
* @param $url 请求url
|
|
* @param $jsonStr 发送的json字符串
|
|
* @return array
|
|
*/
|
|
function http_post_json($url, $jsonStr)
|
|
{
|
|
$ch = curl_init();
|
|
curl_setopt($ch, CURLOPT_POST, 1);
|
|
curl_setopt($ch, CURLOPT_URL, $url);
|
|
curl_setopt($ch, CURLOPT_POSTFIELDS, $jsonStr);
|
|
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
|
|
curl_setopt($ch, CURLOPT_HTTPHEADER, array(
|
|
'Content-Type: application/json; charset=utf-8',
|
|
'Content-Length: ' . strlen($jsonStr)
|
|
)
|
|
);
|
|
$response = curl_exec($ch);
|
|
$httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
|
|
curl_close($ch);
|
|
|
|
return array($httpCode, $response);
|
|
}
|
|
|
|
/**
|
|
* 获取复权因子
|
|
* @return array
|
|
*/
|
|
function getAdj(){
|
|
$url = "http://api.waditu.com";
|
|
$param['api_name']='adj_factor';
|
|
$param['token']='1bc28452ba375da19320cda845ae6307578964cb3ae473d0dc702aea';
|
|
$param['params'] = array('ts_code' => ts_code_conv($_REQUEST['ts_code']),
|
|
'start_date'=>str_replace('-','',$_REQUEST['t_start']),
|
|
'end_date'=>str_replace('-','',$_REQUEST['t_end'])
|
|
);
|
|
$param['fields'] ="";
|
|
$jsonStr=json_encode($param);
|
|
list($returnCode, $returnContent) = http_post_json($url, $jsonStr);
|
|
$arr = json_decode($returnContent,true);
|
|
$items = $arr['data']['items'];
|
|
$lastAdj=$items[0][2];
|
|
foreach ($items as $t){
|
|
list($ts_code,$date,$adj)=$t;
|
|
$rt[$date]=$adj/$lastAdj;
|
|
}
|
|
return $rt;
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
* 获取个股融资融券余额信息
|
|
* @return mixed
|
|
*/
|
|
function getMarginByCode(){
|
|
$url = "http://api.waditu.com";
|
|
$param['api_name']='margin_detail';
|
|
$param['token']='1bc28452ba375da19320cda845ae6307578964cb3ae473d0dc702aea';
|
|
$param['params'] = array('ts_code' => ts_code_conv($_REQUEST['ts_code']),
|
|
'start_date'=>str_replace('-','',$_REQUEST['t_start']),
|
|
'end_date'=>str_replace('-','',$_REQUEST['t_end'])
|
|
);
|
|
$param['fields'] ="";
|
|
$jsonStr=json_encode($param);
|
|
list($returnCode, $returnContent) = http_post_json($url, $jsonStr);
|
|
$arr = json_decode($returnContent,true);
|
|
return $arr['data'];
|
|
}
|
|
|
|
/**
|
|
* @param $exchange SSE OR SZSE, set null for all
|
|
* @return mixed
|
|
*/
|
|
function getMarginAll($exchange){
|
|
|
|
$url = "http://api.waditu.com";
|
|
$param['api_name']='margin_detail';
|
|
$param['token']='1bc28452ba375da19320cda845ae6307578964cb3ae473d0dc702aea';
|
|
$param['params'] = array(
|
|
'start_date'=>str_replace('-','',$_REQUEST['t_start']),
|
|
'end_date'=>str_replace('-','',$_REQUEST['t_end']),
|
|
'exchange_id'=>$exchange
|
|
);
|
|
$param['fields'] ="";
|
|
$jsonStr=json_encode($param);
|
|
list($returnCode, $returnContent) = http_post_json($url, $jsonStr);
|
|
$arr = json_decode($returnContent,true);
|
|
return $arr['data'];
|
|
}
|
|
|
|
/**
|
|
* 沪深港通资金流向
|
|
* @return mixed
|
|
*/
|
|
function getMoneyFlowHSGT(){
|
|
$url = "http://api.waditu.com";
|
|
$param['api_name']='moneyflow_hsgt';
|
|
$param['token']='1bc28452ba375da19320cda845ae6307578964cb3ae473d0dc702aea';
|
|
$param['params'] = array(
|
|
'start_date'=>'20200601',
|
|
'end_date'=>date('Ymd')
|
|
);
|
|
$param['fields'] ="";
|
|
$jsonStr=json_encode($param);
|
|
list($returnCode, $returnContent) = http_post_json($url, $jsonStr);
|
|
$arr = json_decode($returnContent,true);
|
|
return $arr['data'];
|
|
}
|
|
|
|
/**
|
|
* 获取A股个股香港资金持股每日数据
|
|
* @return mixed
|
|
*/
|
|
function getHKHoldByCode(){
|
|
$url = "http://api.waditu.com";
|
|
$param['api_name']='hk_hold';
|
|
$param['token']='1bc28452ba375da19320cda845ae6307578964cb3ae473d0dc702aea';
|
|
$param['params'] = array(
|
|
'ts_code' => ts_code_conv($_REQUEST['ts_code']),
|
|
'start_date'=>str_replace('-','',$_REQUEST['t_start']),
|
|
'end_date'=>str_replace('-','',$_REQUEST['t_end'])
|
|
);
|
|
$param['fields'] ="";
|
|
$jsonStr=json_encode($param);
|
|
list($returnCode, $returnContent) = http_post_json($url, $jsonStr);
|
|
$arr = json_decode($returnContent,true);
|
|
return $arr['data'];
|
|
}
|
|
/**
|
|
* 使用复权因子对股价和成交股数进行复权
|
|
* @param $adj
|
|
* @param $data
|
|
* @return mixed
|
|
*/
|
|
function adjData($adj,$data){
|
|
$num = count($data);
|
|
for($i=0;$i<$num;$i++){
|
|
$t = str_replace('-','',$data[$i]['tdate']);
|
|
$data[$i]['tprice']=round($data[$i]['tprice']*$adj[$t],3);
|
|
$data[$i]['tvol']=round($data[$i]['tvol']/$adj[$t],0);
|
|
}
|
|
return $data;
|
|
}
|
|
/**
|
|
*
|
|
0] => trade_date
|
|
[1] => ts_code
|
|
[2] => rzye
|
|
[3] => rqye
|
|
[4] => rzmre
|
|
[5] => rqyl
|
|
[6] => rzche
|
|
[7] => rqchl
|
|
[8] => rqmcl
|
|
[9] => rzrqye
|
|
https://tushare.pro/document/2?doc_id=58
|
|
*/
|
|
function marginByCodeReform($data){
|
|
$data['items']=array_reverse($data['items']);
|
|
foreach($data['items'] as $rec){
|
|
$dataRT[]=array('value'=>array(date('Y-m-d',strtotime($rec[0])),$rec[9]/10000/10000));
|
|
$val[]=$rec[9]/10000/10000;
|
|
}
|
|
$data_last= round($val[count($val)-1],2);
|
|
$data_max= round(max($val),2);
|
|
$data_min= round(min($val),2);
|
|
if(count($val)>0) $data_avg= round(array_sum($val)/count($val),2);
|
|
else $data_avg=null;
|
|
return array('data'=>$dataRT,'data_max'=>$data_max,'data_min'=>$data_min,'data_avg'=>$data_avg,'data_last'=>$data_last);
|
|
}
|
|
|
|
|
|
/**
|
|
* 计算累积值
|
|
* @param $data
|
|
* @return array
|
|
*/
|
|
function moneyFlowStacked($data){
|
|
$keys=array_keys($data['fields']);
|
|
$num = count($data['items']);
|
|
foreach ($keys as $key) {
|
|
$tmp = 0;
|
|
for($i=0; $i<$num; $i++){
|
|
//keep trade_date field NOT changed.
|
|
if($key > 0)$tmp += $data['items'][$i][$key];
|
|
else $tmp = $data['items'][$i][$key];
|
|
$items[$i][$key]=$tmp;
|
|
}
|
|
}
|
|
return array('fields'=>$data['fields'],'items'=>$items);
|
|
}
|
|
|
|
/**
|
|
* 根据日期截取数据
|
|
* @param $data
|
|
* @param $s start date yyyymmdd
|
|
* @param $e end date yyyymmdd
|
|
* @return array|false
|
|
*/
|
|
function moneyFlowDateFilter($data,$s,$e){
|
|
if($s>$e) return false;
|
|
$num = count($data['items']);
|
|
$items = array();
|
|
for($i=0;$i<$num;$i++){
|
|
if($data['items'][$i][0]>= $s and $data['items'][$i][0]<= $e)
|
|
$items[]=$data['items'][$i];
|
|
}
|
|
return array('fields'=>$data['fields'],'items'=>$items);
|
|
}
|
|
|
|
/**
|
|
*$hsgt :
|
|
[0] => trade_date
|
|
[1] => ggt_ss
|
|
[2] => ggt_sz
|
|
[3] => hgt
|
|
[4] => sgt
|
|
[5] => north_money
|
|
[6] => south_money
|
|
*/
|
|
function moneyFlowReform($data,$hsgt){
|
|
$data['items']=array_reverse($data['items']);
|
|
$key = array_search($hsgt,$data['fields']);
|
|
foreach($data['items'] as $rec){
|
|
$dataRT[]=array('value'=>array(date('Y-m-d',strtotime($rec[0])),$rec[$key]/100));
|
|
$val[]=$rec[$key]/100; //单位：亿元
|
|
}
|
|
$data_last= round($val[count($val)-1],2);
|
|
$data_max= round(max($val),2);
|
|
$data_min= round(min($val),2);
|
|
if(count($val)>0) $data_avg= round(array_sum($val)/count($val),2);
|
|
else $data_avg=null;
|
|
return array('data'=>$dataRT,'data_max'=>$data_max,'data_min'=>$data_min,'data_avg'=>$data_avg,'data_last'=>$data_last);
|
|
}
|
|
/**
|
|
* $hkhold:
|
|
* 0 code
|
|
* 1 trade_date
|
|
* 2 ts_code
|
|
* 3 name
|
|
* 4 vol
|
|
* 5 ratio
|
|
* 6 exchange
|
|
*
|
|
*/
|
|
function hkHoldReform($data,$hkhold){
|
|
//print_r($data);
|
|
$data['items']=array_reverse($data['items']);
|
|
$key = array_search($hkhold,$data['fields']);
|
|
foreach($data['items'] as $rec){
|
|
if($hkhold=='vol') $rec[$key] = $rec[$key]/10000; //万股
|
|
$dataRT[]=array('value'=>array(date('Y-m-d',strtotime($rec[1])),$rec[$key]));
|
|
$val[]=$rec[$key];
|
|
}
|
|
$data_last= round($val[count($val)-1],2);
|
|
$data_max= round(max($val),2);
|
|
$data_min= round(min($val),2);
|
|
if(count($val)>0) $data_avg= round(array_sum($val)/count($val),2);
|
|
else $data_avg=null;
|
|
return array('data'=>$dataRT,'data_max'=>$data_max,'data_min'=>$data_min,'data_avg'=>$data_avg,'data_last'=>$data_last);
|
|
} |