update

config.inc.php

@@ -18,11 +18,11 @@ header("content-type:text/html;charset=utf-8");
 date_default_timezone_set('PRC');              //时区设置，服务器放置在国外的需要打开此项
 session_start();
 //ob_start();
-define("PROJECTCODE",  'boniu');          //项目编号，建议修改，每个项目应该不同
-$HTTP_PATH = 'https://www.zhimawork.com/';     //网站访问路径，根据实际情况修改，务必以“/”结尾。
+define("PROJECTCODE",  'ZhimaPHP');          //项目编号，建议修改，每个项目应该不同
+$HTTP_PATH = 'boniu.xazhima.com/';     //网站访问路径，根据实际情况修改，务必以“/”结尾。
 
 //数据库连接参数设置=======================================
-$DB_host   = 'localhost';                      //数据库地址
+$DB_host   = '47.94.0.230';                      //数据库地址
 $DB_user   = 'boniu';                           //数据库用户
 $DB_pass   = '*boniu#';                           //数据库用户密码
 $DB_name   = 'boniu';                       //数据库名称

data/test.php

@@ -0,0 +1,10 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: 王刚涛
+ * Date: 2020/11/24
+ * Time: 19:16
+ */
+require('../init.php');
+
+sina::get_day_k_base(601006);

init.php

@@ -53,5 +53,6 @@ $mylog = new MyLog($LOG_config);
 $mypdo = new MyPdo();
 $mypdo->debug($DB_DEBUG_LEVEL);
 $dbconn = $mypdo->dbconnect($DB_host, $DB_user, $DB_pass, $DB_name, $DB_prefix);
+//var_dump($dbconn);
 if(!$dbconn) die('数据库连接错误！');
 

lib/common/mypdo.class.php

@@ -10,7 +10,7 @@
  * @createtime	2018/03/01
  * @author		空竹
  * @copyright	芝麻开发 (http://www.zhimawork.com)
- * 
+ *
  * 该类的使用方法简介：
  *
  * ------------SQL查询---------
@@ -20,7 +20,7 @@
  * $sql = "select * from shop where shop_name = $name ";
  * 执行查询:
  * $mypdo->sqlQuery($sql);
- * 
+ *
  * ------------SQL写入---------
  * 示例：
  * $param = array(
@@ -49,7 +49,7 @@
  */
 
 class MyPdo {
-    
+
     public  $pdo      = null;
 	public  $hostname = '';
 	public  $username = '';
@@ -58,7 +58,7 @@ class MyPdo {
     public  $debug    = false;
 	public  $log      = null;
 	public  $logSQL   = false;
-	
+
 	public function __construct(){
 		global $mylog;
 		$this->log = $mylog;
@@ -66,7 +66,7 @@ class MyPdo {
 	public function dbconnect($hostname, $username, $password, $database, $prefix) {
 		$dsn = 'mysql:dbname='.$database.';host='.$hostname.';port=3306';
 		try {
-			$mypdo = new PDO($dsn, $username, $password); 
+			$mypdo = new PDO($dsn, $username, $password);
 			$mypdo -> query('set names utf8;');
 			$mypdo -> setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
 			$this->pdo = $mypdo;
@@ -76,7 +76,7 @@ class MyPdo {
 			if($this->debug) echo $e->getMessage();
 		}
 	}
-	
+
 	//数据库调试
 	public function debug($level = 0){
 		switch($level){
@@ -94,7 +94,7 @@ class MyPdo {
 				break;
 		}
 	}
-	
+
 	//查询
 	//本函数用于执行查询语句，增删改语句请使用其他专用函数
 	//@return 查询结果集array()。
@@ -105,7 +105,7 @@ class MyPdo {
 			//统计查询语句数量2016/6/16
 			$sqlactstr = strtolower(substr($sql, 0, 6));
 			if($sqlactstr == 'select') $CountSQLSelect++;
-			
+
 			$rs = $this -> pdo -> query($sql);
 			$i = 0;
 			$data = array();
@@ -114,7 +114,7 @@ class MyPdo {
 				$i++;
 			}
 			$rs->closeCursor();
-			
+
 			//2018/11/14记录SQL
 			if($this->logSQL) {
 				$this->log->debug($sql, 0);
@@ -131,30 +131,56 @@ class MyPdo {
 		}
 	}
 
+    /***
+     * @param $sql
+     * @return mixed
+     * 执行sql
+     */
+    public function execSql($sql)
+    {
+        try {
+           $mypdo = new MyPdo();//这里框架中的pdo不能用
+
+            $mypdo->exec($sql);//2018/11/14记录SQL
+            if($this->logSQL) {
+                $this->log->debug($sql, 0);
+            }
+            return $this->getLastId();
+        } catch(PDOException $e) {
+            $msg = $e->getMessage().'【错误的SQL语句：'.$sql.'】';
+            if($this->debug) {
+                echo $msg;
+            }else{
+                $this->log->debug($msg, 0);
+            }
+        }
+    }
+
 	//插入
-	//@param $param可选值 
+	//@param $param可选值
 	//             string--表示字符串；
-	//             number--表示数字 
+	//             number--表示数字
 	//             expression--表达式
 	//@return 成功执行返回刚插入的ID；
-	public function sqlinsert($table, $param){
 
+
+	public function sqlinsert($table, $param){
 		if(!is_array($param)){
 			throw new Exception('sqlinsert参数错误', 905);
 		}
 		$sql = 'insert into '.$table.'(';
-		
+
 		$keys = array_keys($param);
 		$keys_str = implode(',', $keys);
 		$sql .= $keys_str.') values(';
-		
+
 		$params = array();
 		foreach($param as $val){
 			$params[] = $this->sql_check_input($val);
 		}
 		$params_str = implode(',', $params);
 		$sql .= $params_str.')';
-
+var_dump($sql);
 		try {
 			$this->pdo->exec($sql);
 
@@ -191,7 +217,7 @@ class MyPdo {
 		$wheres_str = implode(' and ', $wheres);
 
 		$sql .= $wheres_str;
-		
+
 		try {
 			$num = $this->pdo->exec($sql);
 
@@ -235,7 +261,7 @@ class MyPdo {
 		$wheres_str = implode(' and ', $wheres);
 
 		$sql .= ' where '.$wheres_str;
-		
+
 
 		try {
 			$num = $this->pdo->exec($sql);
@@ -262,7 +288,7 @@ class MyPdo {
 	public function sql_check_input($arr_val)
 	{
 		$value = $arr_val[1];
-		
+
 		if (get_magic_quotes_gpc())
 		{
 			$value = stripslashes($value);
@@ -290,7 +316,7 @@ class MyPdo {
 
 	/**
 	 * sql_escape_mimic  用于在无mysql连接情况下替代mysql_real_escape_string的作用（防止SQL注入）
-	 * 
+	 *
 	 * @param mixed $str
 	 * @return
 	 */

lib/day_k_base.class.php

@@ -8,15 +8,21 @@
  */
 class Day_k_base {
 
-	/**
-	 * 记录管理员日志
-	 * 
-	 * @param $log       日志内容
-	 * 
-	 */
-	static public function add($log){
 
-	}
+    /***
+     * @param $attrs
+     * @return mixed
+     * @throws Exception
+     * 添加信息
+     */
+    static public function add($attrs)
+    {
+        if (empty($attrs)) throw new Exception('参数不能为空', 102);
+        $Table_day_k_base = new Table_day_k_base();
+        $id = $Table_day_k_base->add($attrs);
+        return $id;
+    }
+
     
 	/** 
 	 * 管理员日志记录列表

lib/netEasy.class.php

@@ -0,0 +1,374 @@
+<?php
+/**
+ * @author:王刚涛
+ * 用于获取 并存入数据库，通过$url,可以设置需要获取的时间段
+ */
+error_reporting( E_ALL&~E_NOTICE );
+	
+	
+class netEasy
+{	
+public function get($code){
+	$stock_code = $code;	
+	if (Stock_info::checkCode($code))
+	{
+		return -1;
+	}
+	$end_date = date("Ymd", time());
+	$f = substr($stock_code, 0, 1);
+	if ($f == "6")
+	{
+		$stock_code = "0".$code;
+	}
+	else
+	{
+		$stock_code = "1".$code;
+	}
+	$start_date = date("Ymd", time() - 86400*10);
+	$url = "http://quotes.money.163.com/service/chddata.html?code=".$stock_code."&start=".$start_date."&end=".$end_date."&fields=TOPEN;HIGH;LOW;TCLOSE;VATURNOVER;VOTURNOVER;";
+//echo($url);	
+	$flag = 0;
+	//echo $stock_code;
+	//构建所要发送的url			
+	$curlHandle = curl_init(); 
+	curl_setopt( $curlHandle , CURLOPT_URL, $url );
+	curl_setopt( $curlHandle , CURLOPT_RETURNTRANSFER, 1 ); 
+	curl_setopt( $curlHandle , CURLOPT_SSL_VERIFYPEER, false);
+	curl_setopt( $curlHandle , CURLOPT_SSL_VERIFYHOST, false);
+	curl_setopt( $curlHandle , CURLOPT_TIMEOUT, 10 ); 
+	$content = curl_exec($curlHandle);
+	curl_close( $curlHandle );
+	$content1 = explode("'",$content);
+//print_r($content);
+	if(!empty($content1[1])){
+			
+	for($i=count($content1)-1;$i>=0;$i--){
+			
+		if(!empty($content1[$i])){	 
+			  $content2 = explode(",",iconv("gbk","utf-8",$content1[$i]));
+			 } 
+		//解析返回的历史数据
+		if($i==0){
+			$date = str_replace("-","",$content2[9]);
+			$t = explode("-",$content2[9]);
+			}else{
+			$date = str_replace("-","",$content2[8]);
+			
+		    $t = explode("-",$content2[8]);	
+				}
+			$content3 = explode(",",iconv("gbk","utf-8",$content1[$i+1]));
+			//$date = str_replace(" ","", $date);
+			//print_r($content3);
+			//print_r($t);
+			$date = trim($t[0].$t[1].$t[2]);
+			$time = mktime(0,0,0,floatval($t[1]),floatval($t[2]),floatval($t[0]));
+			
+			
+			
+			$data['time'] = $time;
+			$data['date'] = $date;
+			$data['code'] = $content3[0];
+			//$data['name'] = $content3[1];
+			$data['open'] = floatval($content3[2]);
+			$data['high'] = floatval($content3[3]);
+			$data['low']  = floatval($content3[4]);
+			$data['close'] = floatval($content3[5]);
+			$data['turnover'] = floatval($content3[6])/1000000;
+			$data['volume'] = floatval($content3[7]);
+			$data['weeknum'] = floatval($t[0]).''.date('W',trim($time));
+			$data['monthnum'] = floatval($t[0]).''.intval(date('m',$time));
+			//将所要存储的数据放入一个数组中
+			$stock_name = $content3[1];
+		if($data['close']==0){
+			continue;
+	    }	
+			//echo "$date=>$content3[0]";
+		if(!empty($date)){
+			
+			//$datas[] = $data;
+			Stock_info::add($stock_name,$content3[0]);
+			//将这支股票的股票名称和股票代码存入
+			K_line::insert($data);
+			//将这支股票的历史数据存入数据库
+			//var_dump($data);
+			$flag = 1;
+		  }
+		$data = null;
+	 }
+	//k_line::insertweekandmonth($datas);
+	 }
+	 	$content = null;
+		$content2 = null;
+		$content3 = null;
+	 return $flag;
+	 }	
+
+//获取前复权数据
+public function getRec($code, $year){
+	$stock_code = $code;
+	$f = substr($stock_code, 0, 1);
+	if ($f == "6")
+	{
+		$stock_code = "0".$code;
+	}
+	else
+	{
+		$stock_code = "1".$code;
+	}
+	$url = "http://img1.money.126.net/data/hs/klinederc/day/history/".$year."/".$stock_code.".json";
+echo($url."\n");	
+	$flag = 0;
+	//echo $stock_code;
+	//构建所要发送的url			
+	$curlHandle = curl_init(); 
+	curl_setopt( $curlHandle , CURLOPT_URL, $url );
+	curl_setopt( $curlHandle , CURLOPT_RETURNTRANSFER, 1 ); 
+	curl_setopt( $curlHandle , CURLOPT_SSL_VERIFYPEER, false);
+	curl_setopt( $curlHandle , CURLOPT_SSL_VERIFYHOST, false);
+	curl_setopt( $curlHandle , CURLOPT_TIMEOUT, 10 ); 
+	$content = curl_exec($curlHandle);
+	curl_close( $curlHandle );
+	$j = json_decode($content);
+	$data = $j->data;
+	for ($i = 0; $i < count($data); $i++)
+	{
+		$d = $data[$i];
+		$time = strtotime($d[0]);
+		$a['time'] = $time;
+		$a['date'] = $d[0];
+		$a['code'] = $code;
+		$a['open'] = floatval($d[1]);
+		$a['high'] = floatval($d[3]);
+		$a['low']  = floatval($d[4]);
+		$a['close'] = floatval($d[2]);
+		$a['turnover'] = floatval($d[5]);
+		$a['volume'] = floatval($d[5]);
+		$a['weeknum'] = $year.''.date('W',trim($time));
+		$a['monthnum'] = $year.''.intval(date('m',$time));
+		Rec_k_line::insert($a);
+	}
+	return $flag;
+}	
+
+	
+public function getIndex($code){
+	/*
+	if (Index::checkCode($code))
+	{
+		return -1;
+	}
+	*/
+	$end_date = date("Ymd", time());
+	$start_date = date("Ymd", time() - 86400*10);
+	
+	$url = "http://quotes.money.163.com/service/chddata.html?code=".$code."&start=".$start_date."&end=".$end_date."&fields=TOPEN;HIGH;LOW;TCLOSE;VATURNOVER;VOTURNOVER;";
+//echo($url);	
+	$flag = 0;
+	//echo $stock_code;
+	//构建所要发送的url			
+	$curlHandle = curl_init(); 
+	curl_setopt( $curlHandle , CURLOPT_URL, $url );
+	curl_setopt( $curlHandle , CURLOPT_RETURNTRANSFER, 1 ); 
+	curl_setopt( $curlHandle , CURLOPT_SSL_VERIFYPEER, false);
+	curl_setopt( $curlHandle , CURLOPT_SSL_VERIFYHOST, false);
+	curl_setopt( $curlHandle , CURLOPT_TIMEOUT, 10 ); 
+	$content = curl_exec($curlHandle);
+	curl_close( $curlHandle );
+	$content1 = explode("'",$content);
+//print_r($content);
+	if(!empty($content1[1])){
+			
+	for($i=count($content1)-1;$i>=0;$i--){
+			
+		if(!empty($content1[$i])){	 
+			  $content2 = explode(",",iconv("gbk","utf-8",$content1[$i]));
+			 } 
+		//解析返回的历史数据
+		if($i==0){
+			$date = str_replace("-","",$content2[9]);
+			$t = explode("-",$content2[9]);
+			}else{
+			$date = str_replace("-","",$content2[8]);
+			
+		    $t = explode("-",$content2[8]);	
+				}
+			$content3 = explode(",",iconv("gbk","utf-8",$content1[$i+1]));
+			//$date = str_replace(" ","", $date);
+			//print_r($content3);
+			//print_r($t);
+			$date = trim($t[0].$t[1].$t[2]);
+			$time = mktime(0,0,0,floatval($t[1]),floatval($t[2]),floatval($t[0]));
+			
+			
+			
+			$data['time'] = $time;
+			$data['date'] = $date;
+			$data['code'] = $content3[0];
+			//$data['name'] = $content3[1];
+			$data['open'] = floatval($content3[2]);
+			$data['high'] = floatval($content3[3]);
+			$data['low']  = floatval($content3[4]);
+			$data['close'] = floatval($content3[5]);
+			$data['turnover'] = floatval($content3[6])/1000000;
+			$data['volume'] = floatval($content3[7]);
+			$data['weeknum'] = floatval($t[0]).''.date('W',trim($time));
+			$data['monthnum'] = floatval($t[0]).''.intval(date('m',$time));
+			//将所要存储的数据放入一个数组中
+			$stock_name = $content3[1];
+		if($data['close']==0){
+			continue;
+	    }	
+			//echo "$date=>$content3[0]";
+		if(!empty($date)){
+			
+			//$datas[] = $data;
+			Index::add($stock_name,$content3[0]);
+			//将这支股票的股票名称和股票代码存入
+			Index_k_line::insert($data);
+			//将这支股票的历史数据存入数据库
+			//var_dump($data);
+			$flag = 1;
+		  }
+		$data = null;
+	 }
+	//k_line::insertweekandmonth($datas);
+	 }
+	 	$content = null;
+		$content2 = null;
+		$content3 = null;
+	 return $flag;
+	 }
+	 
+//发现新股
+public function get_new($code)
+{
+	$info = Stock_info::getInfoByCode($code);
+ 	if($info)
+ 	{
+ 		//echo ("already in\n");
+ 		return 0;
+ 	}
+
+	$time = time();
+	$url="http://hq.sinajs.cn/list=";
+	if (strncmp($code, "30",2) == 0)
+	{
+		//创业板
+		$url .= "sz";
+	}
+	else if (strncmp($code, "68",2) == 0)
+	{
+		//科创板
+		$url .= "sh";
+	}
+	else if (strncmp($code, "60",2) == 0)
+	{
+		//主板
+		$url .= "sh";
+	}
+	else if (strncmp($code, "00",2) == 0)
+	{
+		//中小板
+		$url .= "sz";
+	}
+	$url .= $code;
+	
+	$curlHandle = curl_init(); 
+	     curl_setopt( $curlHandle , CURLOPT_URL, $url );
+	
+		 
+		 curl_setopt( $curlHandle , CURLOPT_RETURNTRANSFER, 1 ); 
+	     curl_setopt( $curlHandle , CURLOPT_SSL_VERIFYPEER, false);
+	     curl_setopt( $curlHandle , CURLOPT_SSL_VERIFYHOST, false);
+	     curl_setopt( $curlHandle , CURLOPT_TIMEOUT, 10 ); 
+	
+		 $content = curl_exec($curlHandle);
+		 
+//print_r($content);		 
+	     curl_close( $curlHandle );
+		 $content1 = explode('"',$content);
+	
+//print_r($content1);
+		if (!$content1 || $content1[1] == "")
+		{
+//echo("no data");
+			return -1;
+		}
+	$content2 = explode(",",iconv("gb2312","utf-8",$content1[1]));
+//print_r($content2);
+	Stock_info::add($content2[0],$code);
+	return 0;
+}
+
+public function getIndexKLine($code)
+{
+	//填入指数日K信息
+	$time = time();
+	$url="http://hq.sinajs.cn/list=";
+	if (strncmp($code, "3",1) == 0)
+	{
+		//创业板
+		$url .= "sz";
+	}
+	else if (strncmp($code, "0",1) == 0)
+	{
+		//科创板
+		$url .= "sh";
+	}
+	
+	$url .= $code;
+//echo($url."\n");	
+	$curlHandle = curl_init(); 
+	     curl_setopt( $curlHandle , CURLOPT_URL, $url );
+	
+		 
+		 curl_setopt( $curlHandle , CURLOPT_RETURNTRANSFER, 1 ); 
+	     curl_setopt( $curlHandle , CURLOPT_SSL_VERIFYPEER, false);
+	     curl_setopt( $curlHandle , CURLOPT_SSL_VERIFYHOST, false);
+	     curl_setopt( $curlHandle , CURLOPT_TIMEOUT, 10 ); 
+	
+		 $content = curl_exec($curlHandle);
+		 
+//print_r($content);		 
+	     curl_close( $curlHandle );
+		 $content1 = explode('"',$content);
+	
+//print_r($content1);
+		if (!$content1 || $content1[1] == "")
+		{
+//echo("no data");
+			return -1;
+		}
+		$content2 = explode(",",iconv("gb2312","utf-8",$content1[1]));
+		$t = explode("-",$content2[30]);	
+		 $date1 =trim($t[0].$t[1].$t[2]);
+		 
+		 $time = mktime(0,0,0,floatval($t[1]),floatval($t[2]),floatval($t[0]));
+		 
+		 
+		 $close = floatval($content2[3]);
+		 $volume = floatval($content2[8]);
+		 $turnover = floatval($content2[9]/10000);
+		 
+		 $data2['code'] = $code;
+		 $data2['date'] = $date1; 
+		 $data2['time'] = $time;
+		 $data2['open'] = floatval($content2[1]);
+		 $data2['high'] = floatval($content2[4]);
+		 $data2['low'] = floatval($content2[5]);
+		 $data2['close'] = floatval($close);
+		 $data2['volume'] = 0;//floatval($volume);//成交量（手=100股）
+		 $data2['turnover'] = 0;//floatval($turnover);//成交额 = 当前价格*当前交易股数
+		 $data2['weeknum'] = floatval($t[0]).''.date('W',trim($time));
+		 $data2['monthnum'] = floatval($t[0]).''.intval(date('m',$time));
+//print_r($data2);
+		Index_k_line::insert($data2);	
+		return 0;
+}	
+
+	 
+}
+	 
+	
+	 
+	 ?>

lib/sina.class.php

@@ -0,0 +1,74 @@
+<?php
+/**
+ * @author:yxh
+ * 用于获取 并存入数据库，通过$url,可以设置需要获取的时间段
+ */
+error_reporting( E_ALL&~E_NOTICE );
+	
+	
+class sina
+{
+//市场上所有的股票 boniu_stock
+    public function get_boniu_stock($code){
+
+    }
+
+
+
+//上证指数表（boniu_index_sh）
+//深成指数表（boniu_index_scz）
+//
+//上证50指数表（boniu_index_sh50）
+//沪深300指数表（boniu_index_csi300）
+//创业板指数表（boniu_index_gem）
+//科创50指数( boniu_index_kc50)
+//日k线表 day_k_******（每月存一张表，比如boniu_day_k_202011）
+
+    static public function get_day_k_base($code){
+        $stock_code = $code;
+        $f = substr($stock_code, 0, 1);
+        if ($f == "6") {
+            $stock_code = "sh".$code;
+        }
+        else {
+            $stock_code = "1".$code;
+        }
+        $url = "http://hq.sinajs.cn/list=".$stock_code;
+//        var_dump($url);
+        $curlHandle = curl_init();
+        curl_setopt( $curlHandle , CURLOPT_URL, $url );
+        curl_setopt( $curlHandle , CURLOPT_RETURNTRANSFER, 1 );
+        curl_setopt( $curlHandle , CURLOPT_SSL_VERIFYPEER, false);
+        curl_setopt( $curlHandle , CURLOPT_SSL_VERIFYHOST, false);
+        curl_setopt( $curlHandle , CURLOPT_TIMEOUT, 10 );
+        $content = curl_exec($curlHandle);
+        curl_close( $curlHandle );
+        //防止中文乱码
+        $content2 = iconv("gbk","utf-8",$content);
+        //子串
+        $content3=substr($content2,strripos($content2,"=")+1);
+//        var_dump($content3);
+        $content3 = explode(",",$content3);//分割
+//        var_dump($content3);
+        $data['date'] = $content3[30];
+        $data['code'] =$code;
+        $data['open_price'] = $content3[1];//开盘价
+        $data['hightest_price'] = $content3[4];//今日最高价
+        $data['lowest_price'] = floatval($content3[5]);//今日最低价
+        $data['amount']  = $content3[8];//成交的股票数,以百为单位
+        $data['value'] = $content3[9];//成交金额以万为单位
+
+//var_dump($data);
+        return Day_k_base::add($data);
+    }
+
+//除权除息表（boniu_xrxd_log）
+//st记录表（boniu_st_log）
+
+
+
+}
+	 
+	
+	 
+	 ?>

lib/table/table_day_k_base.class.php

@@ -19,29 +19,28 @@ class Table_day_k_base extends Table {
 	//数据库结构
 	protected function struct(){
 		$attr = array();
-		$attr['id']              = 'day_k_id';
-		$attr['date']            = 'day_k_date';
-		$attr['code']            = 'day_k_code';
-		$attr['type']            = 'day_k_open_price';
-        $attr['multiple']        = 'day_k_close_price';
-        $attr['subprice']        = 'day_k_hightest_price';
-        $attr['oldprice']        = 'day_k_lowest_price';
-        $attr['newprice']        = 'day_k_increase_price';
-        $attr['oldprice']        = 'day_k_increase_value';
-        $attr['newprice']        = 'day_k_turnover';
-        $attr['oldprice']        = 'day_k_amount';
-        $attr['newprice']        = 'day_k_value';
-        $attr['oldprice']        = 'day_k_open_price_qfq';
-        $attr['newprice']        = 'day_k_close_price_qfq';
-        $attr['newprice']        = 'day_k_hightest_price_qfq';
-        $attr['oldprice']        = 'day_k_lowest_price_qfq';
-        $attr['newprice']        = 'day_k_m5';
-        $attr['newprice']        = 'day_k_m10';
-        $attr['oldprice']        = 'day_k_m20';
-        $attr['newprice']        = 'day_k_m60';
-        $attr['newprice']        = 'day_k_kdj';
-        $attr['oldprice']        = 'day_k_macd';
-        $attr['newprice']        = 'day_k_rsi';
+		$attr['id']                 = 'day_k_id';
+		$attr['date']               = 'day_k_date';
+		$attr['code']               = 'day_k_code';
+		$attr['open_price']         = 'day_k_open_price';
+        $attr['close_price']        = 'day_k_close_price';
+        $attr['hightest_price']     = 'day_k_hightest_price';
+        $attr['lowest_price']       = 'day_k_lowest_price';
+        $attr['increase_price']     = 'day_k_increase_price';
+        $attr['increase_value']     = 'day_k_increase_value';
+        $attr['turnover']           = 'day_k_turnover';
+        $attr['amount']             = 'day_k_amount';
+        $attr['value']              = 'day_k_value';
+        $attr['open_price_qfq']     = 'day_k_open_price_qfq';
+        $attr['close_price_qfq']    = 'day_k_close_price_qfq';
+        $attr['hightest_price_qfq'] = 'day_k_hightest_price_qfq';
+        $attr['lowest_price_qfq']   = 'day_k_lowest_price_qfq';
+        $attr['m10']                = 'day_k_m10';
+        $attr['m20']                = 'day_k_m20';
+        $attr['m60']                = 'day_k_m60';
+        $attr['kdj']                = 'day_k_kdj';
+        $attr['macd']               = 'day_k_macd';
+        $attr['rsi']                = 'day_k_rsi';
 		return $attr;
 	}
 
@@ -50,10 +49,11 @@ class Table_day_k_base extends Table {
      * 构造函数，动态获取表的后缀年月
      * 王刚涛
      */
-    public function __construct($base) {
+    public function __construct() {
         $this->base=date("Ym");
-        $this->table_name= "day_k_".$base;//表名不代前缀
-        $this->table_fullname= "boniu_"."day_k_".$base;//表名代前缀
+        $this->table_name= "day_k_".$this->base;//表名不代前缀
+//        $this->table_fullname= "boniu_"."day_k_".$this->base;//表名代前缀
+        $this->table_fullname= "boniu_day_k_".$this->base;//表名代前缀
         $this ->createBaseTable();
     }
 
@@ -62,16 +62,40 @@ class Table_day_k_base extends Table {
      * 王刚涛
      */
      public function createBaseTable(){
-       $sqlarr[] = "CREATE TABLE IF NOT EXISTS `". $this->table_fullname."` as select * from boniu_day_k_base where 0 ";
+         $sql = "CREATE TABLE IF NOT EXISTS `". $this->table_fullname."` as select * from boniu_day_k_base where 0 ";
+         $mypdo = new MyPdo();//这里框架中的pdo不能用
+         $this->pdo=$mypdo;
+         var_dump($this->pdo);
 
-   }
+         $this->pdo->execSql($sql);
+//         die;
 
+   }
 
+    /****
+     * @param $attr
+     * @return mixed
+     * 王刚涛
+     */
     public function add($attr){
         $param = array (
-             'admingroup_name'    => array('string', $attr['name'])
+             'day_k_date'    => array('number', strtotime($attr['date'])),
+             'day_k_code'    => array('number', $attr['code']),
+             'day_k_open_price'    => array('number', $attr['open_price']),
+             'day_k_hightest_price'    => array('number', $attr['hightest_price']),
+             'day_k_lowest_price'    => array('number', $attr['lowest_price']),
+             'day_k_amount'    => array('number', $attr['amount']),
+             'day_k_value'    => array('number', $attr['value']),
         );
-        return $this->pdo->sqlinsert($this->table_fullname, $param);
+//        var_dump($attr);
+//        var_dump($this);
+
+//        $mypdo = new MyPdo();//这里框架中的pdo不能用
+//        $this->pdo=$mypdo;
+//
+        $msg=$this->pdo->sqlinsert($this->table_fullname, $param);
+
+        return $msg;
     }
 
     //获取列表（分页）