| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114 |
- <?php
- /**
- * Created by PhpStorm.
- * User: 王刚涛
- * Date: 2020/11/24
- * Time: 14:51
- */
- class Table_day_k 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 function struct(){
- $attr = array();
- $attr['id'] = 'day_k_id';
- $attr['timestamp'] = 'day_k_timestamp';
- $attr['date'] = 'day_k_date';
- $attr['code'] = 'day_k_code';
- $attr['name'] = 'day_k_name';
- $attr['open_price'] = 'day_k_open_price';
- $attr['close_price'] = 'day_k_close_price';
- $attr['highest_price'] = 'day_k_highest_price';
- $attr['lowest_price'] = 'day_k_lowest_price';
- $attr['increase_price'] = 'day_k_increase_price';
- $attr['increase_ratio'] = 'day_k_increase_ratio';
- $attr['turnover'] = 'day_k_turnover';
- $attr['amount'] = 'day_k_amount';
- $attr['value'] = 'day_k_value';
- $attr['m5'] = 'day_k_m5';
- $attr['m10'] = 'day_k_m10';
- $attr['m20'] = 'day_k_m20';
- $attr['m30'] = 'day_k_m30';
- $attr['m60'] = 'day_k_m60';
- $attr['m233'] = 'day_k_m233';
- $attr['day_k_tradable_amount'] = 'tradable_amount';
- $attr['day_k_tradable_value'] = 'tradable_value';
- $attr['day_k_total_amount'] = 'total_amount';
- $attr['day_k_total_value'] = 'total_value';
- $attr['day_k_profitable'] = 'profitable';
- $attr['day_k_pb'] = 'pb';
- $attr['day_k_pe_static'] = 'pe_static';
- $attr['day_k_pe_dynamic'] = 'pe_dynamic';
- $attr['day_k_pe_ttm'] = 'pe_ttm';
- return $attr;
- }
- /****
- * @param $attr
- * @return mixed
- * 王刚涛
- */
- public function add($attr){
- $param = array (
- 'day_k_timestamp ' => array('number', $attr['timestamp']),
- 'day_k_date' => array('number', $attr['date']),
- 'day_k_code' => array('string', $attr['code']),
- 'day_k_name' => array('string', $attr['name']),
- 'day_k_open_price' => array('number', $attr['open_price']),
- 'day_k_close_price' => array('number', $attr['close_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']),
- 'day_k_increase_price' => array('number', $attr['increase_price']),// 涨跌价
- 'day_k_increase_ratio' => array('number', $attr['increase_ratio']),// 涨跌幅
- 'day_k_turnover' => array('number', $attr['turnover']),// 换手率
- 'day_k_pe_ttm' => array('number', $attr['pe_ttm']),
- 'day_k_tradable_value' => array('number', $attr['tradable_value']),
- 'day_k_total_value' => array('number', $attr['total_value']),
- 'day_k_pb' => array('number', $attr['pb']),
- 'day_k_pe_dynamic' => array('number', $attr['pe_dynamic']),
- 'day_k_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 (
- 'day_k_date' => array('number', strtotime($attr['date'])),
- 'day_k_code' => array('number', $attr['code']),
- 'day_k_name' => array('string', $attr['name']),
- '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_value' => array('number', $attr['value']),
- 'day_k_amount' => array('number', $attr['amount']),
- 'day_k_close_price' => array('number', $attr['close_price']),
- 'day_k_close_price_qfq' => array('number', $attr['close_price_qfq']),
- 'day_k_increase_price' => array('number', $attr['increase_price']),
- 'day_k_increase_value' => array('number', $attr['increase_value']),
- 'day_k_turnover' => array('number', $attr['turnover']),
- );
- $msg=$this->pdo->sqlinsert($this->table_fullname, $param);
- return $msg;
- }
- }
- ?>
|