where('stock_id', 'JPY') ->field("change_type, stock_id as name, change_num, create_time, order_id"); // 第二张表 $query2 = Db::name('user_stock_block_log') ->where('user_id', $userId) ->where('stock_id', 'JPY') ->field("change_type, stock_id as name, change_num, create_time, order_id"); // 合并 SQL $unionSql = $query1->unionAll($query2->buildSql(), true)->buildSql(); // 查询分页数据 $list = Db::table("({$unionSql}) t") ->order('create_time desc') ->limit($offset, $pageSize) ->select() ->toArray(); // 总数 $count1 = self::where('user_id', $userId)->where('stock_id', 'JPY')->count(); $count2 = Db::name('user_stock_block_log')->where('user_id', $userId)->where('stock_id', 'JPY')->count(); $total = $count1 + $count2; return [ 'total' => $total, 'list' => $list, ]; } // public static function getUserBalanceLog(array $data):array // { // $where['user_id']=$data['user_id']; // $where['stock_id']='JPY'; // $count=self::where($where)->count(); // if($data['page']<1){ // $data['page']=1; // } // if($data['page_size']<1){ // $data['page_size']=10; // } // $list = self::where($where)->field('change_type,stock_id as name,change_num,create_time,order_id')->order('id desc')->page($data['page'],$data['page_size'])->select(); // if(empty($list)){ // return []; // } // return [ // 'total'=>$count, // 'list'=>$list->toArray(), // ]; // } public static function InsertUserBalanceLog(array $data) { $self = new self; $self->user_id = $data['user_id']; $self->stock_id = $data['stock_id']; $self->change_type = $data['change_type']; $self->change_num = $data['change_num']; if (isset($data['order_id'])) { $self->order_id = $data['order_id']; } $self->before_num = $data['before_num']; $self->create_time = date('Y-m-d H:i:s'); $self->update_time = date('Y-m-d H:i:s'); return $self->save(); } }