boniu/lib/table/table_day_k_base.class.php

<?php

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

class Table_day_k_base extends Table {

    protected $base  = "";              //分表的后缀日期,在进行数据库操作的时候"Table_day_k_".$base
    protected $table_name       = "day_k_";//表名，不带前缀，前缀在config中定义
    protected $table_id         = "day_k_id";//指定ID字段名称，必须
    protected $table_status     = '';//指定状态字段名称，如果有
    protected $table_order      = '';//指定排序字段名称，如果有
    protected $table_fullname    = "day_k_";//拼接好后表名  后面拼接日期  day_k_202011

	//数据库结构
	protected function struct(){
		$attr = array();
		$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;
	}

    /***
     * Table_day_k_base constructor.
     * 构造函数，动态获取表的后缀年月
     * 王刚涛
     */
    public function __construct($date) {
        parent::__construct();
        $this->table_name .= $date;//表名不代前缀
        $this->table_fullname .= $date;//表名代前缀
        //$this ->createBaseTable();
    }

    /****
     *在构造函数中调用该函数，自动创建表
     * 王刚涛
     */
     public function createBaseTable(){
//         $mypdo = new MyPdo();//这里框架中的pdo不能用
//         $this->pdo=$mypdo;
         $sql = " CREATE TABLE IF NOT EXISTS `". $this->table_fullname."` as select * from boniu_day_k_base where 0 ";
//         var_dump($sql);
//         $this->pdo->execSql($sql);

   }

    /****
     * @param $attr
     * @return mixed
     * 王刚涛
     */
    public function add($attr){
        $param = array (
             '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']),
        );
//        var_dump($this->pdo);
//        var_dump($this);

//        $mypdo = new MyPdo();//这里框架中的pdo不能用
//        $this->pdo=$mypdo;


        $msg=$this->pdo->sqlinsert($this->table_fullname, $param);

        return $msg;
    }

    //获取列表（分页）
    //$count、$page和$pagesize都为0时，返回全部结果（适用于无需分页的情况）
    //
    //@param $filter array -- 过滤条件，格式见Table::filterToWhere
    //@param $count -- 0：返回列表 1：返回结果数量
    //@param $page -- 当前第几页
    //@param $pagesize -- 每页数量
    public function getList($filter = array(), $count = 0, $page = 0, $pagesize = 0)
    {

    }
}
?>