package art.servers.sosserver.controller.musatel;
|
|
import art.library.interop.serialization.Serialization;
|
import art.library.model.devices.sos.Sos;
|
import art.library.model.devices.sos.musatel.information.SosInformationMusatelConnection;
|
import art.library.model.devices.sos.musatel.status.SosStatusMusatelConnection;
|
import art.library.utils.synchro.Mutex;
|
import art.servers.Shared;
|
import java.io.IOException;
|
import java.io.InputStream;
|
import java.io.OutputStream;
|
import java.net.InetAddress;
|
import java.net.InetSocketAddress;
|
import java.net.Socket;
|
import java.net.SocketAddress;
|
|
|
|
|
public class ControllerSos_MusatelSender
|
{
|
private ControllerSos_Musatel controller = null;
|
private Socket socket = null;
|
private InputStream is = null;
|
private OutputStream os = null;
|
private Mutex mutex = new Mutex();
|
private String name = null;
|
|
|
public ControllerSos_MusatelSender(ControllerSos_Musatel controller)
|
{
|
this.controller = controller;
|
this.name = controller.getName();
|
}
|
|
|
|
// <editor-fold defaultstate="collapsed" desc="Actions">
|
|
protected void ORD_FON_ON (String username, String computer, String computerAddress, int audioPort, int priority) throws Exception
|
{
|
Sos clone = (Sos)Serialization.clone(controller.getDevice());
|
byte[] address = MusatelProtocol.getIpArray(computerAddress);
|
Shared.println(name, "> ORD_FON_ON " + computerAddress + ":" + audioPort);
|
function(MusatelProtocol.ORD_FON_ON, new int[]{address[0], address[1], address[2], address[3],(byte)(audioPort & 0xFF),(byte)((audioPort >> 8) & 0xFF)});
|
|
SosStatusMusatelConnection connection = new SosStatusMusatelConnection();
|
clone.getDeviceStatus().musatel.currentConnection = connection;
|
connection.timestamp = System.currentTimeMillis();
|
connection.user = username;
|
connection.computer = computer;
|
connection.address = computerAddress;
|
connection.audioPort = audioPort;
|
connection.priority = priority;
|
controller.setSosPriority(priority);
|
|
Shared.model.updateDevice(controller.getDevice(), clone);
|
}
|
|
|
protected void ORD_FON_ON (String computerAddress, int audioPort) throws Exception
|
{
|
Shared.println(name, "> ORD_FON_ON " + computerAddress + ":" + audioPort);
|
byte[] address = MusatelProtocol.getIpArray(computerAddress);
|
function(MusatelProtocol.ORD_FON_ON, new int[]{address[0], address[1], address[2], address[3],(byte)(audioPort & 0xFF),(byte)((audioPort >> 8) & 0xFF)});
|
}
|
|
|
protected void ORD_FON_OFF () throws Exception
|
{
|
Shared.println(name, "> ORD_FON_OFF");
|
function(MusatelProtocol.ORD_FON_OFF);
|
}
|
|
|
protected void ORD_TON_ON (String computerAddress, int audioPort, int type) throws Exception
|
{
|
Shared.println(name, "> ORD_TON_ON " + computerAddress + ":" + audioPort);
|
byte[] address = MusatelProtocol.getIpArray(computerAddress);
|
function(MusatelProtocol.ORD_TON_ON, new int[]{type, address[0], address[1], address[2], address[3],(byte)(audioPort & 0xFF),(byte)((audioPort >> 8) & 0xFF)});
|
}
|
|
protected void ORD_TON_OFF () throws Exception
|
{
|
Shared.println(name, "> ORD_TON_OFF");
|
function(MusatelProtocol.ORD_TON_OFF);
|
}
|
|
|
protected void ORD_TST_MAN () throws Exception
|
{
|
Shared.println(name, "> ORD_TST_MAN");
|
function(new byte[]{(byte)0x00, (byte)MusatelProtocol.ORD_TST_MAN, (byte)0xFF, (byte)0xFF});
|
}
|
|
|
protected void ORD_TST_FON (String computerAddress, int audioPort) throws Exception
|
{
|
Shared.println(name, "> ORD_TST_FON " + computerAddress + ":" + audioPort);
|
byte[] address = MusatelProtocol.getIpArray(computerAddress);
|
function(MusatelProtocol.ORD_TST_FON, new int[]{address[0], address[1], address[2], address[3],(byte)(audioPort & 0xFF),(byte)((audioPort >> 8) & 0xFF)});
|
}
|
|
|
|
protected void ORD_VOZ_ON(String username, String computer, String computerAddress, int audioPort, int message) throws Exception
|
{
|
Shared.println(name, "> ORD_VOZ_ON " + computerAddress + ":" + audioPort);
|
byte[] address = MusatelProtocol.getIpArray(computerAddress);
|
function(MusatelProtocol.ORD_FON_ON, new int[]{(byte)message, address[0], address[1], address[2], address[3],(byte)(audioPort & 0xFF),(byte)((audioPort >> 8) & 0xFF)});
|
}
|
|
|
|
protected void ORD_VOZ_OFF () throws Exception
|
{
|
Shared.println(name, "> ORD_VOZ_OFF");
|
function(MusatelProtocol.ORD_VOZ_OFF);
|
}
|
|
|
|
protected void ORD_ADJ_VOL (int level) throws Exception
|
{
|
if (level < 0) level = 0;
|
if (level > 7) level = 7;
|
Shared.println(name, "> ORD_ADJ_VOL " + Shared.getMessage("level") + " = " + level);
|
function(MusatelProtocol.ORD_ADJ_VOL, new int[]{level});
|
}
|
|
|
|
|
protected void ACK_DEM_USE() throws Exception
|
{
|
Shared.println(name, "> ACK_DEM_USE");
|
function(MusatelProtocol.ACK_DEM_USE, new int[]{MusatelProtocol.L_ESP});
|
}
|
|
|
protected void ACK_DEM_USE(String computerAddress, int audioPort) throws Exception
|
{
|
Shared.println(name, "> ACK_DEM_USE " + computerAddress + ":" + audioPort);
|
|
byte[] address = MusatelProtocol.getIpArray(computerAddress);
|
|
function(MusatelProtocol.ACK_DEM_USE, new int[]
|
{
|
MusatelProtocol.L_FON,
|
address[0],
|
address[1],
|
address[2],
|
address[3],
|
(byte)(audioPort & 0xFF),
|
(byte)((audioPort >> 8) & 0xFF)
|
});
|
}
|
|
|
|
protected void ACK_DEM_SER() throws Exception
|
{
|
Shared.println(name, "> ACK_DEM_SER");
|
function(MusatelProtocol.ACK_DEM_SER, new int[]{MusatelProtocol.L_ESP});
|
}
|
|
|
|
protected void ACK_DEM_SER(String computerAddress, int audioPort) throws Exception
|
{
|
Shared.println(name, "> ACK_DEM_SER " + computerAddress + ":" + audioPort);
|
|
byte[] address = MusatelProtocol.getIpArray(computerAddress);
|
|
function(MusatelProtocol.ACK_DEM_USE, new int[]
|
{
|
MusatelProtocol.L_FON,
|
address[0],
|
address[1],
|
address[2],
|
address[3],
|
(byte)(audioPort & 0xFF),
|
(byte)((audioPort >> 8) & 0xFF)
|
});
|
}
|
|
|
|
|
protected void ACK_ENV_ALA() throws Exception
|
{
|
Shared.println(name, "> ACK_ENV_ALA");
|
function(MusatelProtocol.ACK_ENV_ALA);
|
}
|
|
// </editor-fold>
|
|
|
|
|
// <editor-fold defaultstate="collapsed" desc="Communications">
|
|
|
private void connect () throws Exception
|
{
|
if (socket != null)
|
{
|
if (socket.isConnected() == true)
|
{
|
return;
|
}
|
}
|
|
|
disconnect();
|
|
SosInformationMusatelConnection connection = ((Sos)controller.getDevice()).getDeviceInformation().musatel.connection;
|
InetAddress inetAddress = InetAddress.getByName(connection.address);
|
SocketAddress sockaddress = new InetSocketAddress(inetAddress, connection.portSOS);
|
socket = new Socket();
|
socket.connect(sockaddress, connection.timeout);
|
socket.setSoLinger (true, 1);
|
socket.setSoTimeout(connection.timeout);
|
is = socket.getInputStream();
|
os = socket.getOutputStream();
|
}
|
|
|
|
private void function (int code) throws Exception
|
{
|
function(code, MusatelProtocol.P_MAS, new int[0]);
|
}
|
|
|
private void function (int code, int[] params) throws Exception
|
{
|
function(code, (byte)MusatelProtocol.P_MAS, params);
|
}
|
|
|
private void function (int code, int type, int[] params) throws Exception
|
{
|
byte[] send = new byte[5 + params.length];
|
send[0] = 0x00;
|
send[1] = (byte)code;
|
send[2] = (byte)type;
|
|
for (int i=0; i<params.length; i++)
|
{
|
send[3 + i] = (byte)params[i];
|
}
|
|
send[3 + params.length] = (byte)0xFF;
|
send[4 + params.length] = (byte)0xFF;
|
|
function(send);
|
}
|
|
|
|
private void function (byte[] send) throws Exception
|
{
|
mutex.lockWrite();
|
|
try
|
{
|
connect();
|
|
String command = ">";
|
|
for (int i=0; i<send.length; i++)
|
{
|
command = command + " " + String.format("%02X", send[i]);
|
}
|
|
Sos sos = controller.getDevice();
|
SosInformationMusatelConnection connection = sos.getDeviceInformation().musatel.connection;
|
socket.setSoTimeout(connection.timeout);
|
os.write(send);
|
os.flush();
|
Shared.println(controller.getName(), command);
|
}
|
catch (IOException exception)
|
{
|
disconnect();
|
throw exception;
|
}
|
catch (Exception exception)
|
{
|
throw exception;
|
}
|
finally
|
{
|
mutex.releaseWrite();
|
}
|
}
|
|
|
|
|
|
private void disconnect ()
|
{
|
try { os.close(); } catch (Exception e) { }
|
try { socket.close(); } catch (Exception e) { }
|
try { is.close(); } catch (Exception e) { }
|
|
socket = null;
|
os = null;
|
is = null;
|
}
|
|
// </editor-fold>
|
|
|
}
|
