nextcloud/apps/media/lib_collection.php

381 lines
11 KiB
PHP

<?php
/**
* ownCloud - media plugin
*
* @author Robin Appelman
* @copyright 2010 Robin Appelman icewind1991@gmail.com
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU AFFERO GENERAL PUBLIC LICENSE
* License as published by the Free Software Foundation; either
* version 3 of the License, or any later version.
*
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU AFFERO GENERAL PUBLIC LICENSE for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this library. If not, see <http://www.gnu.org/licenses/>.
*
*/
//class for managing a music collection
class OC_MEDIA_COLLECTION{
public static $uid;
private static $artistIdCache=array();
private static $albumIdCache=array();
private static $songIdCache=array();
private static $queries=array();
/**
* get the id of an artist (case-insensitive)
* @param string name
* @return int
*/
public static function getArtistId($name){
if(empty($name)){
return 0;
}
$name=strtolower($name);
if(isset(self::$artistIdCache[$name])){
return self::$artistIdCache[$name];
}else{
$query=OC_DB::prepare("SELECT artist_id FROM *PREFIX*media_artists WHERE artist_name LIKE ?");
$artists=$query->execute(array($name))->fetchAll();
if(is_array($artists) and isset($artists[0])){
self::$artistIdCache[$name]=$artists[0]['artist_id'];
return $artists[0]['artist_id'];
}else{
return 0;
}
}
}
/**
* get the id of an album (case-insensitive)
* @param string name
* @param int artistId
* @return int
*/
public static function getAlbumId($name,$artistId){
if(empty($name)){
return 0;
}
$name=strtolower($name);
if(!isset(self::$albumIdCache[$artistId])){
self::$albumIdCache[$artistId]=array();
}
if(isset(self::$albumIdCache[$artistId][$name])){
return self::$albumIdCache[$artistId][$name];
}else{
$query=OC_DB::prepare("SELECT album_id FROM *PREFIX*media_albums WHERE album_name LIKE ? AND album_artist=?");
$albums=$query->execute(array($name,$artistId))->fetchAll();
if(is_array($albums) and isset($albums[0])){
self::$albumIdCache[$artistId][$name]=$albums[0]['album_id'];
return $albums[0]['album_id'];
}else{
return 0;
}
}
}
/**
* get the id of an song (case-insensitive)
* @param string name
* @param int artistId
* @param int albumId
* @return int
*/
public static function getSongId($name,$artistId,$albumId){
if(empty($name)){
return 0;
}
$name=strtolower($name);
if(!isset(self::$albumIdCache[$artistId])){
self::$albumIdCache[$artistId]=array();
}
if(!isset(self::$albumIdCache[$artistId][$albumId])){
self::$albumIdCache[$artistId][$albumId]=array();
}
if(isset(self::$albumIdCache[$artistId][$albumId][$name])){
return self::$albumIdCache[$artistId][$albumId][$name];
}else{
$uid=$_SESSION['user_id'];
$query=OC_DB::prepare("SELECT song_id FROM *PREFIX*media_songs WHERE song_user=? AND song_name LIKE ? AND song_artist=? AND song_album=?");
$songs=$query->execute(array($uid,$name,$artistId,$albumId))->fetchAll();
if(is_array($songs) and isset($songs[0])){
self::$albumIdCache[$artistId][$albumId][$name]=$songs[0]['song_id'];
return $songs[0]['song_id'];
}else{
return 0;
}
}
}
/**
* Get the list of artists that (optionally) match a search string
* @param string search optional
* @return array the list of artists found
*/
static public function getArtists($search='%',$exact=false){
if(!$exact and $search!='%'){
$search="%$search%";
}elseif($search==''){
$search='%';
}
$query=OC_DB::prepare("SELECT DISTINCT *PREFIX*media_artists.artist_name AS artist_name , *PREFIX*media_artists.artist_id AS artist_id FROM *PREFIX*media_artists
INNER JOIN *PREFIX*media_songs ON *PREFIX*media_artists.artist_id=*PREFIX*media_songs.song_artist WHERE artist_name LIKE ? AND *PREFIX*media_songs.song_user=?");
return $query->execute(array($search,self::$uid))->fetchAll();
}
/**
* Add an artists to the database
* @param string name
* @return integer the artist_id of the added artist
*/
static public function addArtist($name){
$name=trim($name);
if($name==''){
return 0;
}
//check if the artist is already in the database
$artistId=self::getArtistId($name);
if($artistId!=0){
return $artistId;
}else{
$query=OC_DB::prepare("INSERT INTO `*PREFIX*media_artists` (`artist_id` ,`artist_name`) VALUES (NULL , ?)");
$result=$query->execute(array($name));
return self::getArtistId($name);;
}
}
/**
* Get the list of albums that (optionally) match an artist and/or search string
* @param integer artist optional
* @param string search optional
* @return array the list of albums found
*/
static public function getAlbums($artist=0,$search='%',$exact=false){
$cmd="SELECT DISTINCT *PREFIX*media_albums.album_name AS album_name , *PREFIX*media_albums.album_artist AS album_artist , *PREFIX*media_albums.album_id AS album_id
FROM *PREFIX*media_albums INNER JOIN *PREFIX*media_songs ON *PREFIX*media_albums.album_id=*PREFIX*media_songs.song_album WHERE *PREFIX*media_songs.song_user=? ";
$params=array(self::$uid);
if($artist!=0){
$cmd.="AND *PREFIX*media_albums.album_artist = ? ";
array_push($params,$artist);
}
if($search!='%'){
$cmd.="AND *PREFIX*media_albums.album_name LIKE ? ";
if(!$exact){
$search="%$search%";
}
array_push($params,$search);
}
$query=OC_DB::prepare($cmd);
return $query->execute($params)->fetchAll();
}
/**
* Add an album to the database
* @param string name
* @param integer artist
* @return integer the album_id of the added artist
*/
static public function addAlbum($name,$artist){
$name=trim($name);
if($name==''){
return 0;
}
//check if the album is already in the database
$albumId=self::getAlbumId($name,$artist);
if($albumId!=0){
return $albumId;
}else{
$query=OC_DB::prepare("INSERT INTO `*PREFIX*media_albums` (`album_id` ,`album_name` ,`album_artist`) VALUES (NULL , ?, ?)");
$query->execute(array($name,$artist));
return self::getAlbumId($name,$artist);
}
}
/**
* Get the list of songs that (optionally) match an artist and/or album and/or search string
* @param integer artist optional
* @param integer album optional
* @param string search optional
* @return array the list of songs found
*/
static public function getSongs($artist=0,$album=0,$search='',$exact=false){
$uid=self::$uid;
if(empty($uid)){
$uid=self::$uid=$_SESSION['user_id'];
}
$params=array($uid);
if($artist!=0){
$artistString="AND song_artist = ?";
array_push($params,$artist);
}else{
$artistString='';
}
if($album!=0){
$albumString="AND song_album = ?";
array_push($params,$album);
}else{
$albumString='';
}
if($search){
if(!$exact){
$search="%$search%";
}
$searchString ="AND song_name LIKE ?";
array_push($params,$search);
}else{
$searchString='';
}
$query=OC_DB::prepare("SELECT * FROM *PREFIX*media_songs WHERE song_user=? $artistString $albumString $searchString");
return $query->execute($params)->fetchAll();
}
/**
* Add an song to the database
* @param string name
* @param string path
* @param integer artist
* @param integer album
* @return integer the song_id of the added artist
*/
static public function addSong($name,$path,$artist,$album,$length,$track,$size){
$name=trim($name);
$path=trim($path);
if($name=='' or $path==''){
return 0;
}
$uid=OC_User::getUser();
//check if the song is already in the database
$songId=self::getSongId($name,$artist,$album);
if($songId!=0){
$songInfo=self::getSong($songId);
self::moveSong($songInfo['song_path'],$path);
return $songId;
}else{
if(!isset(self::$queries['addsong'])){
$query=OC_DB::prepare("INSERT INTO `*PREFIX*media_songs` (`song_name` ,`song_artist` ,`song_album` ,`song_path` ,`song_user`,`song_length`,`song_track`,`song_size`,`song_playcount`,`song_lastplayed`)
VALUES (?, ?, ?, ?,?,?,?,?,0,0)");
self::$queries['addsong']=$query;
}else{
$query=self::$queries['addsong'];
}
$query->execute(array($name,$artist,$album,$path,$uid,$length,$track,$size));
$songId=OC_DB::insertid();
// self::setLastUpdated();
return self::getSongId($name,$artist,$album);
}
}
public static function getSongCount(){
$query=OC_DB::prepare("SELECT COUNT(song_id) AS count FROM *PREFIX*media_songs");
$result=$query->execute()->fetchAll();
return $result[0]['count'];
}
public static function getArtistCount(){
$query=OC_DB::prepare("SELECT COUNT(artist_id) AS count FROM *PREFIX*media_artists");
$result=$query->execute()->fetchAll();
return $result[0]['count'];
}
public static function getAlbumCount(){
$query=OC_DB::prepare("SELECT COUNT(album_id) AS count FROM *PREFIX*media_albums");
$result=$query->execute()->fetchAll();
return $result[0]['count'];
}
public static function getArtistName($artistId){
$query=OC_DB::prepare("SELECT artist_name FROM *PREFIX*media_artists WHERE artist_id=?");
$artist=$query->execute(array($artistId))->fetchAll();
if(count($artist)>0){
return $artist[0]['artist_name'];
}else{
return '';
}
}
public static function getAlbumName($albumId){
$query=OC_DB::prepare("SELECT album_name FROM *PREFIX*media_albums WHERE album_id=?");
$album=$query->execute(array($albumId))->fetchAll();
if(count($album)>0){
return $album[0]['album_name'];
}else{
return '';
}
}
public static function getSong($id){
$query=OC_DB::prepare("SELECT * FROM *PREFIX*media_songs WHERE song_id=?");
$song=$query->execute(array($id))->fetchAll();
if(count($song)>0){
return $song[0];
}else{
return '';
}
}
/**
* get the number of songs in a directory
* @param string $path
*/
public static function getSongCountByPath($path){
$query=OC_DB::prepare("SELECT COUNT(song_id) AS count FROM *PREFIX*media_songs WHERE song_path LIKE ?");
$result=$query->execute(array("$path%"))->fetchAll();
return $result[0]['count'];
}
/**
* remove a song from the database by path
* @param string $path the path of the song
*
* if a path of a folder is passed, all songs stored in the folder will be removed from the database
*/
public static function deleteSongByPath($path){
$query=OC_DB::prepare("DELETE FROM *PREFIX*media_songs WHERE song_path LIKE ?");
$query->execute(array("$path%"));
}
/**
* increase the play count of a song
* @param int songId
*/
public static function registerPlay($songId){
$now=time();
$query=OC_DB::prepare('UPDATE *PREFIX*media_songs SET song_playcount=song_playcount+1, song_lastplayed=? WHERE song_id=? AND song_lastplayed<?');
$query->execute(array($now,$songId,$now-60));
}
/**
* get the id of the song by path
* @param string $path
* @return int
*/
public static function getSongByPath($path){
$query=OC_DB::prepare("SELECT song_id FROM *PREFIX*media_songs WHERE song_path = ?");
$result=$query->execute(array($path));
if($row=$result->fetchRow()){
return $row['song_id'];
}else{
return 0;
}
}
/**
* set the path of a song
* @param string $oldPath
* @param string $newPath
*/
public static function moveSong($oldPath,$newPath){
$query=OC_DB::prepare("UPDATE *PREFIX*media_songs SET song_path = ? WHERE song_path = ?");
$query->execute(array($newPath,$oldPath));
}
}
?>