boniu/lib/table/table_index_day_k.class.php

<?php

/**
 * Created by PhpStorm.
 * User: 王刚涛
 * Date: 2020/11/24
 * Time: 14:51
 */

class Table_index_day_k extends Table {

    protected $table_name       = "index_day_k";//表名，不带前缀，前缀在config中定义
    protected $table_id         = "index_day_k_id";//指定ID字段名称，必须

	//数据库结构
	protected function struct(){
		$attr = array();
		$attr['id']                 = 'index_day_k_id';
        $attr['timestamp']          = 'index_day_k_timestamp';
		$attr['date']               = 'index_day_k_date';
		$attr['code']               = 'index_day_k_code';
        $attr['name']               = 'index_day_k_name';
        $attr['open_price']         = 'index_day_k_open_price';
        $attr['close_price']        = 'index_day_k_close_price';
        $attr['highest_price']     = 'index_day_k_highest_price';
        $attr['lowest_price']       = 'index_day_k_lowest_price';
        $attr['increase_price']     = 'index_day_k_increase_price';
        $attr['increase_ratio']     = 'index_day_k_increase_ratio';
        $attr['amount']             = 'index_day_k_amount';
        $attr['value']              = 'index_day_k_value';

		return $attr;
	}



    public function index_recent_days($code,$start_date,$traceback_days,$order)
    {
        //查询语句必须用sql_check_input检查参数
        $stock_code = $this->pdo->sql_check_input(array('string', $code));//类型是字符串，那一定要在条件中将数据使用引号引用起来,否则不使用索引
        $sql = "select * from ". $this->table_fullname ." where 1=1 ";
        $where =" and index_day_k_code=".$stock_code." and index_day_k_date <=".$start_date  ;
        $sql.=$where;
        $orderInfo=" ORDER BY index_day_k_date desc";
        $sql.=$orderInfo;
        $limit=" limit ".$traceback_days;
        $sql.=$limit;
        if($order==1){
            $sql=   " SELECT a.* FROM "."($sql) a ORDER BY a.index_day_k_date desc ";

        }else{
            $sql=   " SELECT a.* FROM "."($sql) a ORDER BY a.index_day_k_date asc";
        }
        $rs = $this->pdo->sqlQuery($sql);
        $r  = array();
        if($rs){
            foreach($rs as $key => $val){

                $r[$key] = $this->dataToAttr($val);
            }
            return $r;
        }else{
            return $r;
        }
    }

    /***
     * @param $code
     * @param $date
     * @return array
     * wanggangtao
     * 获取某天的指数代码
     */
    public function get_current_day_index($index_type,$date)
    {
        //查询语句必须用sql_check_input检查参数
        $stock_code = $this->pdo->sql_check_input(array('number', $index_type));//类型是字符串，那一定要在条件中将数据使用引号引用起来,否则不使用索引
        $sql = "select * from ". $this->table_fullname ;

        $where=" where 1=1 ";
        if($index_type==1){
            $stock_code="000001";
            $where.=" and index_day_k_code=".$stock_code ;
        }else if($index_type==2){
            $stock_code="399001";
            $where.=" and index_day_k_code=".$stock_code ;
        }else if($index_type==3){
            $stock_code="000016";
            $where.=" and index_day_k_code=".$stock_code ;
        }else if($index_type==4){
            $stock_code="399300";
            $where.=" and index_day_k_code=".$stock_code ;
        }else if($index_type==5){
            $stock_code="399006";
            $where.=" and index_day_k_code=".$stock_code ;
        }else if($index_type==6){
            $stock_code="000688";
            $where.=" and index_day_k_code=".$stock_code ;
        }


        if($date==0){//获取的是当天的数据
            $date = date("Ymd",time());
            $where.=" and index_day_k_date = ".$date;

        }else{//获取某一天的数据
            $date = $this->pdo->sql_check_input(array('number', $date));
            $where.=" and index_day_k_date =".$date;
        }
        $sql.=$where;

        $rs = $this->pdo->sqlQuery($sql);
        $r  = array();
        if($rs){
            foreach($rs as $key => $val){

                $r[$key] = $this->dataToAttr($val);
            }
            return $r;
        }else{
            return $r;
        }
    }

    /****
     * @param $start_date
     * @param $end_date
     * @param $index_type
     * @param $num
     * @param $order_info
     * @return array
     * wanggangtao
     */
    public function getIndexListHistroy($start_date,$end_date,$index_type,$num,$order_info)
    {
        //查询语句必须用sql_check_input检查参数
        $start_date= $this->pdo->sql_check_input(array('number', $start_date));
        $end_date = $this->pdo->sql_check_input(array('number', $end_date));
        $sql = "select * from ". $this->table_fullname ." where 1=1 ";
        if($index_type==1){
            $stock_code="000001";
            $sql.=" and index_day_k_code=".$stock_code ;
        }else if($index_type==2){
            $stock_code="399001";
            $sql.=" and index_day_k_code=".$stock_code ;
        }else if($index_type==3){
            $stock_code="000016";
            $sql.=" and index_day_k_code=".$stock_code ;
        }else if($index_type==4){
            $stock_code="399300";
            $sql.=" and index_day_k_code=".$stock_code ;
        }else if($index_type==5){
            $stock_code="399006";
            $sql.=" and index_day_k_code=".$stock_code ;
        }else if($index_type==6){
            $stock_code="000688";
            $sql.=" and index_day_k_code=".$stock_code ;
        }
        $where =" and index_day_k_timestamp between ".$start_date." and ".$end_date ;
        $sql.=$where;

        if($order_info==1){
            $order=" order by index_day_k_timestamp desc ";
        }else{
            $order=" order by index_day_k_timestamp asc ";

        }
        $sql.=$order;

        $limit=" limit ".$num;
        $sql.=$limit;


        $rs = $this->pdo->sqlQuery($sql);
        $r  = array();
        if($rs){
            foreach($rs as $key => $val){

                $r[$key] = $this->dataToAttr($val);
            }
            return $r;
        }else{
            return $r;
        }
    }


    public function add($attr){
        $param = array (

            'index_day_k_timestamp'    => array('number', $attr['timestamp']),
            'index_day_k_date'    => array('number', $attr['date']),
            'index_day_k_code'    => array('string', $attr['code']),
            'index_day_k_name'    => array('string', $attr['name']),
            'index_day_k_open_price'    => array('number', $attr['open_price']),
            'index_day_k_close_price'    => array('number', $attr['close_price']),
            'index_day_k_highest_price'    => array('number', $attr['highest_price']),
            'index_day_k_lowest_price'    => array('number', $attr['lowest_price']),
            'index_day_k_increase_price'    => array('number', $attr['increase_price']),
            'index_day_k_increase_ratio'    => array('number', $attr['increase_ratio']),
            'index_day_k_amount'    => array('number', $attr['amount']),
            'index_day_k_value'    => array('number', $attr['value']),        );
        return $this->pdo->sqlinsert($this->table_fullname, $param);
    }


    /***
     * @param $attr
     * @return mixed
     * 历史指数数据
     */
    public function insert($attr){
        $param = array (

            'index_day_k_timestamp'    => array('number', $attr['timestamp']),
            'index_day_k_date'    => array('number', $attr['date']),
            'index_day_k_code'    => array('string', $attr['code']),
            'index_day_k_name'    => array('string', $attr['name']),
            'index_day_k_open_price'    => array('number', $attr['open_price']),
            'index_day_k_close_price'    => array('number', $attr['close_price']),
            'index_day_k_highest_price'    => array('number', $attr['highest_price']),
            'index_day_k_lowest_price'    => array('number', $attr['lowest_price']),
            'index_day_k_increase_price'    => array('number', $attr['increase_price']),
            'index_day_k_increase_ratio'    => array('number', $attr['increase_ratio']),
            'index_day_k_amount'    => array('number', $attr['amount']),
            'index_day_k_value'    => array('number', $attr['value']),        );
        return $this->pdo->sqlinsert($this->table_fullname, $param);
    }

}
?>