/*
|
* Radiozentrale - Webradio App
|
* Copyright (C) 2018 Ulrich Hilger, http://uhilger.de
|
*
|
* This program is free software: you can redistribute it and/or modify
|
* it under the terms of the GNU General Public License as published by
|
* the Free Software Foundation, either version 3 of the License, or
|
* (at your option) any later version.
|
*
|
* This program 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 General Public License for more details.
|
*
|
* You should have received a copy of the GNU General Public License
|
* along with this program. If not, see http://www.gnu.org/licenses/
|
*/
|
|
package de.uhilger.radiozentrale.api;
|
|
import de.uhilger.baselink.PersistenceManager;
|
import de.uhilger.radiozentrale.daten.Abspieler;
|
import de.uhilger.radiozentrale.daten.Sender;
|
import de.uhilger.radiozentrale.web.Initialiser;
|
import java.net.HttpURLConnection;
|
import java.net.URL;
|
import java.sql.Connection;
|
import java.util.List;
|
import java.util.logging.Level;
|
import java.util.logging.Logger;
|
|
/**
|
*
|
*/
|
public class AbspielerApi extends DbApi {
|
|
private static final Logger logger = Logger.getLogger(AbspielerApi.class.getName());
|
|
public static final String KEY_ABSPIELER_ID = "abs_id";
|
public static final String ABSPIELER_SELECTED = "selected";
|
public static final String SQL_GET_ABSPIELER_LIST = "getAbspielerList";
|
public static final String SQL_UNSEL_ABSPIELER = "unselectAbspieler";
|
|
|
/**
|
* Einen neuen Abspieler in der Datenbank speichern
|
*
|
* @param abspieler der neue Abspieler
|
* return der Abspieler nach dem Speichern (mit ID)
|
*/
|
public Abspieler neuerAbspieler(Abspieler abspieler) {
|
Abspieler neuerAbspieler = null;
|
PersistenceManager db = getDb();
|
Connection c = db.getConnection();
|
db.startTransaction(c);
|
int nextKey = getNextId(db, KEY_ABSPIELER_ID);
|
if(nextKey > -1) {
|
if(abspieler.getZustand().equals(ABSPIELER_SELECTED)) {
|
db.execute(getSql(SQL_UNSEL_ABSPIELER), "", ABSPIELER_SELECTED);
|
}
|
abspieler.setId(nextKey);
|
Object o = db.insert(abspieler, getMapper(Initialiser.MP_ABSPIELER));
|
if(o instanceof Abspieler) {
|
neuerAbspieler = (Abspieler) o;
|
db.commit(c);
|
logger.fine("Abspieler erstellt: " + abspieler.getId() + " " + abspieler.getName());
|
} else {
|
db.rollback(c);
|
logger.info("Abspieler konnte nicht erstellt werden: " + abspieler.getName());
|
}
|
} else {
|
db.rollback(c);
|
logger.info("Abspieler konnte nicht erstellt werden, nextKey ist -1");
|
}
|
return neuerAbspieler;
|
}
|
|
public Abspieler abspielerAendern(Abspieler abspieler) {
|
Abspieler geaendert = null;
|
PersistenceManager db = getDb();
|
Connection c = db.getConnection();
|
db.startTransaction(c);
|
if(abspieler.getZustand().equals(ABSPIELER_SELECTED)) {
|
db.execute(getSql(SQL_UNSEL_ABSPIELER), "", ABSPIELER_SELECTED);
|
}
|
Object o = db.update(abspieler, getMapper(Initialiser.MP_ABSPIELER));
|
if(o instanceof Abspieler) {
|
geaendert = (Abspieler) o;
|
db.commit(c);
|
logger.fine("Abspieler geaendert: " + abspieler.getId() + " " + abspieler.getName());
|
} else {
|
db.rollback(c);
|
}
|
return geaendert;
|
}
|
|
public Abspieler abspielerLoeschen(Abspieler abspieler) {
|
Abspieler geloescht = null;
|
Object o = getDb().delete(abspieler, getMapper(Initialiser.MP_ABSPIELER));
|
if(o instanceof Abspieler) {
|
geloescht = (Abspieler) o;
|
logger.fine("Abspieler geloescht: " + abspieler.getId() + " " + abspieler.getName());
|
}
|
return geloescht;
|
}
|
|
public List abspielerliste() {
|
return getDb().select(getSql(SQL_GET_ABSPIELER_LIST), getMapper(Initialiser.MP_ABSPIELER));
|
}
|
|
public String abspielen(int abspielerId, int senderId) {
|
Abspieler a = getAbspieler(abspielerId);
|
Sender s = getSender(senderId);
|
StringBuffer url = new StringBuffer();
|
url.append(a.getUrl());
|
url.append("/sys/rpc?c=de.uhilger.pirc.App&m=abspielenMitParametern&p=");
|
url.append(s.getUrl());
|
url.append("&p=-o%20local&p=");
|
return abspielerKommandoSenden(url.toString());
|
}
|
|
public String abspielenStoppen(int abspielerId) {
|
Abspieler a = getAbspieler(abspielerId);
|
StringBuffer url = new StringBuffer();
|
url.append(a.getUrl());
|
url.append("/sys/rpc?c=de.uhilger.pirc.App&m=kommando&p=q");
|
return abspielerKommandoSenden(url.toString());
|
}
|
}
|
