package art.servers.sosserver.controller.musatel;
|
|
import art.library.model.devices.sos.Sos;
|
import art.servers.Shared;
|
import art.servers.controller.Controller;
|
import art.servers.controller.ControllerDevice;
|
import java.io.ByteArrayInputStream;
|
import java.io.InputStream;
|
import java.net.DatagramPacket;
|
import java.net.DatagramSocket;
|
import java.util.concurrent.Executors;
|
import java.util.concurrent.ThreadPoolExecutor;
|
|
|
|
public class ListenerSos_Musatel extends Controller
|
{
|
private int port = 0;
|
private String name = null;
|
private ThreadPoolExecutor executor = null;
|
|
public ListenerSos_Musatel(int port)
|
{
|
this.port = port;
|
this.name = Shared.getMessage("Common listener" + ":" + port);
|
}
|
|
public int getPort()
|
{
|
return port;
|
}
|
|
|
public void run()
|
{
|
Shared.traceInformation(name, "Starting");
|
|
executor = (ThreadPoolExecutor)Executors.newCachedThreadPool();
|
|
while (isInterrupted() == false)
|
{
|
try
|
{
|
DatagramSocket socket = new DatagramSocket(port);
|
|
byte[] receive = new byte[8192];
|
|
while (true)
|
{
|
DatagramPacket notification = new DatagramPacket(receive, receive.length);
|
socket.receive(notification);
|
if (notification.getLength() > 0)
|
{
|
Listener listener = new Listener(notification);
|
executor.execute(listener);
|
}
|
}
|
}
|
catch (Exception e)
|
{
|
}
|
}
|
|
executor.shutdown();
|
Shared.traceInformation(name, "Finishing");
|
|
}
|
|
|
|
|
public class Listener implements Runnable // Thread
|
{
|
private DatagramPacket notification = null;
|
private ControllerSos_Musatel controller = null;
|
private InputStream input = null;
|
|
public Listener(DatagramPacket notification)
|
{
|
this.notification = notification;
|
}
|
|
|
public void run()
|
{
|
this.controller = getDeviceController(notification.getAddress().getHostAddress());
|
|
if (controller == null)
|
{
|
return;
|
}
|
|
Shared.println(name, notification.getAddress().getHostAddress());
|
this.input = new ByteArrayInputStream(notification.getData(), 0, notification.getLength());
|
manage();
|
}
|
|
|
private void manage()
|
{
|
try
|
{
|
int address = input.read();
|
int function = input.read();
|
|
String command = "<";
|
command = command + " " + String.format("%02X", address);
|
command = command + " " + String.format("%02X", function);
|
Shared.println(name, command);
|
|
if (controller != null)
|
{
|
switch (function)
|
{
|
case MusatelProtocol.DEM_USE: controller.receiver.DEM_USE(input.read()); break;
|
case MusatelProtocol.DEM_SER: controller.receiver.DEM_SER(input.read()); break;
|
case MusatelProtocol.ENV_ALA : controller.receiver.ENV_ALA(input.read(), input.read()); break;
|
case MusatelProtocol.ACK_FON_ON : controller.receiver.ACK_FON_ON(input.read()); break;
|
case MusatelProtocol.ACK_FON_OFF : controller.receiver.ACK_FON_OFF(input.read()); break;
|
case MusatelProtocol.ACK_TON_ON : controller.receiver.ACK_TON_ON(input.read()); break;
|
case MusatelProtocol.ACK_TON_OFF : controller.receiver.ACK_TON_OFF(input.read()); break;
|
case MusatelProtocol.RES_TST_FON : controller.receiver.RES_TST_FON(input.read(), input.read()); break;
|
case MusatelProtocol.RES_TST_MAN : controller.receiver.RES_TST_MAN(input); break;
|
case MusatelProtocol.ACK_VOZ_ON : controller.receiver.ACK_VOZ_ON(input.read()); break;
|
case MusatelProtocol.ACK_VOZ_OFF : controller.receiver.ACK_VOZ_OFF(input.read()); break;
|
case MusatelProtocol.ACK_ADJ_VOL : controller.receiver.ACK_ADJ_VOL(input.read(), input.read()); break;
|
case MusatelProtocol.NACK : controller.receiver.NACK(input.read()); break;
|
default : controller.receiver.UNKNOWN(function); break;
|
}
|
}
|
else
|
{
|
Shared.println(name, Shared.getMessage("Unknown address") + ", " + notification.getAddress().getHostAddress());
|
}
|
|
int CRC1 = input.read();
|
int CRC2 = input.read();
|
}
|
catch (Exception e)
|
{
|
e.printStackTrace();
|
}
|
}
|
|
|
|
private ControllerSos_Musatel getDeviceController (String address)
|
{
|
try
|
{
|
for (ControllerDevice controller : Shared.getDeviceControllers())
|
{
|
Sos sos = controller.getDevice();
|
|
if (sos.getDeviceInformation().musatel.connection.address.equalsIgnoreCase(address) == true)
|
{
|
return (ControllerSos_Musatel)controller;
|
}
|
}
|
}
|
catch (Exception exception)
|
{
|
}
|
|
return null;
|
}
|
}
|
|
|
|
}
|
