boniu/lib/table/table_immediate_base.class.php

<?php

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

class Table_immediate_base extends Table
{

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

    //数据库结构
    protected function struct()
    {
        $attr = array();
        $attr['id'] = 'immediate_id';
        $attr['date'] = 'immediate_date';
        $attr['code'] = 'immediate_code';
        $attr['name'] = 'immediate_name';
        $attr['open_price'] = 'immediate_open_price';
        $attr['close_price'] = 'immediate_close_price';
        $attr['highest_price'] = 'immediate_highest_price';
        $attr['lowest_price'] = 'immediate_lowest_price';
        $attr['increase_price'] = 'immediate_increase_price';
        $attr['increase_value'] = 'immediate_increase_value';
        $attr['turnover'] = 'immediate_turnover';
        $attr['amount'] = 'immediate_amount';
        $attr['value'] = 'immediate_value';
        $attr['tradable_amount'] = 'immediate_tradable_amount';
        $attr['tradable_value'] = 'immediate_tradable_value';
        $attr['total_amount'] = 'immediate_total_amount';
        $attr['total_value'] = 'immediate_total_value';
        $attr['profitable'] = 'immediate_profitable';
        $attr['pb'] = 'immediate_pb';
        $attr['pe_static'] = 'immediate_pe_static';
        $attr['pe_dynamic'] = 'immediate_pe_dynamic';
        $attr['pe_ttm'] = 'immediate_pe_ttm';


        return $attr;
    }

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

    /****
     *在构造函数中调用该函数，自动创建表
     * 王刚涛
     */
    public function createBaseTable()
    {
        global $mypdo;
        $sql = " CREATE TABLE IF NOT EXISTS `" . $this->table_fullname . "` LIKE  boniu_immediate_base";
        $mypdo->pdo->exec($sql);
    }

    /****
     * @param $attr
     * @return mixed
     * 王刚涛
     */
    public function add($attr)
    {
        $param = array(
            'immediate_timestamp '    => array('number', $attr['timestamp']),
            'immediate_date'          => array('number', $attr['date']),
            'immediate_code'          => array('string', $attr['code']),
            'immediate_name'          => array('string', $attr['name']),
            'immediate_open_price'    => array('number', $attr['open_price']),
            'immediate_close_price'   => array('number', $attr['close_price']),
            'immediate_highest_price' => array('number', $attr['highest_price']),
            'immediate_lowest_price'  => array('number', $attr['lowest_price']),
            'immediate_amount'        => array('number', $attr['amount']),
            'immediate_value'         => array('number', $attr['value']),

            'immediate_increase_price' => array('number', $attr['increase_price']),//  涨跌价
            'immediate_increase_ratio' => array('number', $attr['increase_ratio']),//   涨跌幅
            'immediate_turnover'       => array('number', $attr['turnover']),//    换手率
            'immediate_pe_ttm'         => array('number', $attr['pe_ttm']),
            'immediate_tradable_value' => array('number', $attr['tradable_value']),
            'immediate_total_value'    => array('number', $attr['total_value']),
            'immediate_pb'             => array('number', $attr['pb']),
            'immediate_pe_dynamic'     => array('number', $attr['pe_dynamic']),
            'immediate_pe_static'      => array('number', $attr['pe_static']),
        );
        return $this->pdo->sqlinsert($this->table_fullname, $param);
    }

//    /****
//     * @param $attr
//     * @return mixed
//     *
//     */
//    public function insert($attr)
//    {
//        $param = array(
//            'immediate_date'            => array('number', strtotime($attr['date'])),
//            'immediate_code'            => array('number', $attr['code']),
//            'immediate_name'            => array('string', $attr['name']),
//            'immediate_open_price'      => array('number', $attr['open_price']),
//            'immediate_highest_price'   => array('number', $attr['highest_price']),
//            'immediate_lowest_price'    => array('number', $attr['lowest_price']),
//            'immediate_value'           => array('number', $attr['value']),
//            'immediate_amount'          => array('number', $attr['amount']),
//            'immediate_close_price'     => array('number', $attr['close_price']),
//            'immediate_close_price_qfq' => array('number', $attr['close_price_qfq']),
//            'immediate_increase_price'  => array('number', $attr['increase_price']),
//            'immediate_increase_value'  => array('number', $attr['increase_value']),
//            'immediate_turnover'        => array('number', $attr['turnover']),
//
//        );
//        $msg = $this->pdo->sqlinsert($this->table_fullname, $param);
//        return $msg;
//    }

}

?>