package art.servers.transactionsserver.model.vms;
|
|
import java.awt.image.BufferedImage;
|
import java.io.ByteArrayOutputStream;
|
import art.library.interop.InteropParameters;
|
import art.library.interop.InteropResponse;
|
import art.library.interop.serialization.SerializationException;
|
import art.library.model.devices.Device;
|
import art.library.model.devices.vms.general.VmsGeneral;
|
import art.library.model.devices.vms.general.commands.VmsGeneralCommandsMessage;
|
import art.library.model.devices.vms.general.commands.VmsGeneralCommandsMessageImage;
|
import art.library.model.devices.vms.general.commands.VmsGeneralCommandsMessagePersistence;
|
import art.servers.ServerException;
|
import art.servers.transactionsserver.Shared;
|
import java.sql.ResultSet;
|
import java.util.ArrayList;
|
import java.util.HashSet;
|
import java.util.List;
|
import java.util.Set;
|
import java.util.stream.Collectors;
|
import javax.imageio.ImageIO;
|
|
|
public class ModelVmsMessagesLibrary
|
{
|
public ModelVmsMessagesLibrary()
|
{
|
}
|
|
public InteropResponse addVmsGeneralCommandsMessages(InteropParameters parameters) throws SerializationException
|
{
|
String language = (String) parameters.getParameterValue("language");
|
boolean success = true;
|
|
try
|
{
|
VmsGeneralCommandsMessage lvmsGeneralCommandsMessage[] = parameters.getBodyContentValue(VmsGeneralCommandsMessage[].class);
|
|
for (VmsGeneralCommandsMessage vmsGeneralCommandsMessage : lvmsGeneralCommandsMessage)
|
{
|
try
|
{
|
if (vmsGeneralCommandsMessage.folder == null){vmsGeneralCommandsMessage.folder = "";}
|
Shared.controllerDatabase.getTimelessPersistance().get(0).updateOrAddObject(new VmsGeneralCommandsMessagePersistence(vmsGeneralCommandsMessage));
|
} catch (Exception ex)
|
{
|
success = false;
|
ex.printStackTrace();
|
}
|
}
|
} catch (Exception e)
|
{
|
e.printStackTrace();
|
}
|
return new InteropResponse(new Boolean(success));
|
}
|
|
public InteropResponse removeVmsGeneralCommandsMessages(InteropParameters parameters) throws SerializationException
|
{
|
String language = (String) parameters.getParameterValue("language");
|
boolean success = true;
|
|
try
|
{
|
VmsGeneralCommandsMessage lvmsGeneralCommandsMessage[] = parameters.getBodyContentValue(VmsGeneralCommandsMessage[].class);
|
|
for (VmsGeneralCommandsMessage vmsGeneralCommandsMessage : lvmsGeneralCommandsMessage)
|
{
|
try
|
{
|
if (vmsGeneralCommandsMessage.folder == null){vmsGeneralCommandsMessage.folder = "";}
|
Shared.controllerDatabase.getTimelessPersistance().get(0).deleteObject(new VmsGeneralCommandsMessagePersistence(vmsGeneralCommandsMessage));
|
} catch (Exception ex)
|
{
|
success = false;
|
ex.printStackTrace();
|
}
|
}
|
} catch (Exception e)
|
{
|
e.printStackTrace();
|
}
|
return new InteropResponse(new Boolean(success));
|
}
|
|
@SuppressWarnings("unchecked")
|
public InteropResponse getVmsGeneralCommandsMessages(InteropParameters parameters) throws SerializationException
|
{
|
String language = (String) parameters.getParameterValue("language");
|
List<VmsGeneralCommandsMessagePersistence> lvmsGeneralCommandsMessagePersistence = new ArrayList<>();
|
|
try
|
{
|
String folder = (parameters.hasParameter("folder") == true) ? (String) parameters.getParameterValue("folder") : null;
|
String name = (parameters.hasParameter("name") == true) ? (String)parameters.getParameterValue("name") : null;
|
String type = (parameters.hasParameter("type") == true) ? (String)parameters.getParameterValue("type") : null;
|
|
if (folder != null || name != null || type != null)
|
{
|
String where = "true";
|
if (folder!=null) where+= " and folder='" + folder + "'";
|
if (type!=null) where+= " and type='" + type + "'";
|
if (name != null) where += " and name like '%" + name + "%'";
|
|
lvmsGeneralCommandsMessagePersistence = (List<VmsGeneralCommandsMessagePersistence>) (List<?>) Shared.controllerDatabase.getTimelessPersistance().get(0).getObject(VmsGeneralCommandsMessagePersistence.class.getName(), where);
|
} else
|
{
|
lvmsGeneralCommandsMessagePersistence = (List<VmsGeneralCommandsMessagePersistence>) (List<?>) Shared.controllerDatabase.getTimelessPersistance().get(0).getObject(VmsGeneralCommandsMessagePersistence.class.getName());
|
}
|
List<VmsGeneralCommandsMessage> lvmsGeneralCommandsMessage = lvmsGeneralCommandsMessagePersistence.stream().map(m -> m.message).collect(Collectors.toList());
|
|
return new InteropResponse(lvmsGeneralCommandsMessage.toArray(new VmsGeneralCommandsMessage[0]));
|
} catch (Exception exception)
|
{
|
throw new SerializationException(Shared.getMessage(language, exception.getMessage()), exception);
|
}
|
}
|
|
@SuppressWarnings("unchecked")
|
public InteropResponse getVmsGeneralCommandsMessagesFolders(InteropParameters parameters) throws SerializationException
|
{
|
String language = (String) parameters.getParameterValue("language");
|
Set<String> lfolder = new HashSet<>();
|
|
try
|
{
|
String type = (parameters.hasParameter("type") == true) ? (String)parameters.getParameterValue("type") : null;
|
if (type != null)
|
{
|
List<VmsGeneralCommandsMessagePersistence> lvmsGeneralCommandsMessagePersistence
|
= (List<VmsGeneralCommandsMessagePersistence>) (List<?>) Shared.controllerDatabase.getTimelessPersistance().get(0).getObject(VmsGeneralCommandsMessagePersistence.class.getName(), "type='" + type + "'");
|
|
lfolder = lvmsGeneralCommandsMessagePersistence.stream().map(m -> m.message.folder).collect(Collectors.toSet());
|
}
|
|
return new InteropResponse(lfolder.toArray(new String[0]));
|
} catch (Exception exception)
|
{
|
throw new SerializationException(Shared.getMessage(language, exception.getMessage()), exception);
|
}
|
}
|
|
@SuppressWarnings("unchecked")
|
public InteropResponse getVmsGeneralCommandsMessagesFoldersDevice(InteropParameters parameters) throws SerializationException
|
{
|
String language = (String) parameters.getParameterValue("language");
|
Set<String> lfolder = new HashSet<>();
|
|
try
|
{
|
String type = (parameters.hasParameter("type") == true) ? (String)parameters.getParameterValue("type") : null;
|
String identifier = (parameters.hasParameter("identifier") == true) ? (String)parameters.getParameterValue("identifier") : null;
|
if (identifier == null)
|
{
|
identifier = (parameters.hasParameter("device") == true) ? (String)parameters.getParameterValue("device") : null;
|
}
|
|
if (identifier != null)
|
{
|
Device device = Shared.model.getDeviceExternal(identifier);
|
if (device == null) throw new ServerException("Device does not exist");
|
if (device instanceof VmsGeneral)
|
{
|
type = ((VmsGeneral)device).getDeviceInformation().getResolutionType();
|
}
|
else
|
{
|
throw new ServerException("Device is not a VMS");
|
}
|
}
|
|
if (type != null)
|
{
|
List<VmsGeneralCommandsMessagePersistence> lvmsGeneralCommandsMessagePersistence
|
= (List<VmsGeneralCommandsMessagePersistence>) (List<?>) Shared.controllerDatabase.getTimelessPersistance().get(0).getObject(VmsGeneralCommandsMessagePersistence.class.getName(), "type='" + type + "'");
|
|
lfolder = lvmsGeneralCommandsMessagePersistence.stream().map(m -> m.message.folder).collect(Collectors.toSet());
|
}
|
|
return new InteropResponse(lfolder.toArray(new String[0]));
|
}
|
catch (ServerException exception)
|
{
|
throw new SerializationException(Shared.getMessage(language, exception.getMessage()), exception);
|
}
|
catch (Exception exception)
|
{
|
throw new SerializationException(Shared.getMessage(language, exception.getMessage()), exception);
|
}
|
}
|
|
@SuppressWarnings("unchecked")
|
public InteropResponse getVmsGeneralCommandsMessagesDeviceFolder(InteropParameters parameters) throws SerializationException
|
{
|
String language = (String) parameters.getParameterValue("language");
|
List<VmsGeneralCommandsMessagePersistence> lvmsGeneralCommandsMessagePersistence = new ArrayList<>();
|
|
try
|
{
|
int width = (parameters.hasParameter("width") == true) ? Integer.parseInt((String)parameters.getParameterValue("width")) : 0;
|
int height = (parameters.hasParameter("height") == true) ? Integer.parseInt((String)parameters.getParameterValue("height")) : 0;
|
String folder = (parameters.hasParameter("folder") == true) ? (String)parameters.getParameterValue("folder") : null;
|
String name = (parameters.hasParameter("name") == true) ? (String)parameters.getParameterValue("name") : null;
|
String identifier = (parameters.hasParameter("identifier") == true) ? (String)parameters.getParameterValue("identifier") : null;
|
if (identifier == null)
|
{
|
identifier = (parameters.hasParameter("device") == true) ? (String)parameters.getParameterValue("device") : null;
|
}
|
|
String type = null;
|
if (identifier != null)
|
{
|
Device device = Shared.model.getDeviceExternal(identifier);
|
if (device == null) throw new ServerException("Device does not exist");
|
if (device instanceof VmsGeneral)
|
{
|
type = ((VmsGeneral)device).getDeviceInformation().getResolutionType();
|
// if (width == 0) width = ((VmsGeneral)device).getDeviceInformation().width;
|
// if (height == 0) height = ((VmsGeneral)device).getDeviceInformation().height;
|
}
|
else
|
{
|
throw new ServerException("Device is not a VMS");
|
}
|
}
|
|
if ((folder != null) || (type != null) || (name != null))
|
{
|
String where = "true";
|
if (folder!=null) where+= " and folder='" + folder + "'";
|
if (type!=null) where+= " and type='" + type + "'";
|
if (name!=null) where+= " and name='" + name + "'";
|
|
lvmsGeneralCommandsMessagePersistence = (List<VmsGeneralCommandsMessagePersistence>) (List<?>) Shared.controllerDatabase.getTimelessPersistance().get(0).getObject(VmsGeneralCommandsMessagePersistence.class.getName(), where);
|
} else
|
{
|
lvmsGeneralCommandsMessagePersistence = (List<VmsGeneralCommandsMessagePersistence>) (List<?>) Shared.controllerDatabase.getTimelessPersistance().get(0).getObject(VmsGeneralCommandsMessagePersistence.class.getName());
|
}
|
List<VmsGeneralCommandsMessage> lvmsGeneralCommandsMessage = lvmsGeneralCommandsMessagePersistence.stream().map(m -> m.message).collect(Collectors.toList());
|
List<VmsGeneralCommandsMessageImage> lvmsGeneralCommandsMessageImage = new ArrayList<VmsGeneralCommandsMessageImage>();
|
|
for (VmsGeneralCommandsMessage message : lvmsGeneralCommandsMessage)
|
{
|
VmsGeneralCommandsMessageImage image = new VmsGeneralCommandsMessageImage();
|
image.folder = message.folder;
|
image.name = message.name;
|
image.priority = message.priority;
|
image.time = message.time;
|
image.type = message.type;
|
image.imageType = "png";
|
BufferedImage bufImage = message.document.getRealisticImage(width, height, true);
|
image.height = bufImage.getHeight();
|
image.width = bufImage.getWidth();
|
ByteArrayOutputStream bos = new ByteArrayOutputStream();
|
ImageIO.write(bufImage, "png", bos);
|
bos.flush();
|
image.image = bos.toByteArray();
|
bos.close();
|
bos = null;
|
|
lvmsGeneralCommandsMessageImage.add(image);
|
}
|
|
return new InteropResponse(lvmsGeneralCommandsMessageImage.toArray(new VmsGeneralCommandsMessageImage[0]));
|
}
|
catch (ServerException exception)
|
{
|
throw new SerializationException(Shared.getMessage(language, exception.getMessage()), exception);
|
}
|
catch (Exception exception)
|
{
|
throw new SerializationException(Shared.getMessage(language, exception.getMessage()), exception);
|
}
|
}
|
|
|
@SuppressWarnings("unchecked")
|
public InteropResponse renameVmsGeneralCommandsMessagesFolder(InteropParameters parameters) throws SerializationException
|
{
|
String language = (String) parameters.getParameterValue("language");
|
boolean success = true;
|
try
|
{
|
String selectedPath = ((parameters.hasParameter("selectedPath") == true) && !((String) parameters.getParameterValue("selectedPath")).isEmpty())
|
? (String) parameters.getParameterValue("selectedPath") : "";
|
String newPath = ((parameters.hasParameter("newPath") == true) && !((String) parameters.getParameterValue("newPath")).isEmpty())
|
? (String) parameters.getParameterValue("newPath") : "";
|
String type = (parameters.hasParameter("type") == true) ? (String)parameters.getParameterValue("type") : null;
|
|
String where = "(folder = '" + selectedPath + "' or folder like '" + selectedPath + "/%') and type='" + type + "'";
|
List<VmsGeneralCommandsMessagePersistence> lvmsGeneralCommandsMessagePersistence = (List<VmsGeneralCommandsMessagePersistence>) (List<?>) Shared.controllerDatabase.getTimelessPersistance().get(0).getObject(VmsGeneralCommandsMessagePersistence.class.getName(), where);
|
List<VmsGeneralCommandsMessage> lvmsGeneralCommandsMessage = lvmsGeneralCommandsMessagePersistence.stream().map(m -> m.message).collect(Collectors.toList());
|
|
for (VmsGeneralCommandsMessage vmsGeneralCommandsMessage : lvmsGeneralCommandsMessage)
|
{
|
try
|
{
|
Shared.controllerDatabase.getTimelessPersistance().get(0).deleteObject(new VmsGeneralCommandsMessagePersistence(vmsGeneralCommandsMessage));
|
vmsGeneralCommandsMessage.folder = newPath;
|
Shared.controllerDatabase.getTimelessPersistance().get(0).addObject_asynchronous(new VmsGeneralCommandsMessagePersistence(vmsGeneralCommandsMessage));
|
} catch (Exception e)
|
{
|
success = false;
|
}
|
}
|
return new InteropResponse(success);
|
} catch (Exception exception)
|
{
|
throw new SerializationException(Shared.getMessage(language, exception.getMessage()), exception);
|
}
|
}
|
|
@SuppressWarnings("unchecked")
|
public InteropResponse getVmsGeneralCommandsMessageTypes(InteropParameters parameters) throws SerializationException
|
{
|
String language = (String) parameters.getParameterValue("language");
|
List<String> ltype = new ArrayList<>();
|
|
try
|
{
|
ResultSet res = Shared.controllerDatabase.getTimelessPersistance().get(0).executeQuery("SELECT distinct(type) FROM vms_library");
|
while (res.next())
|
{
|
ltype.add(res.getString(1));
|
}
|
return new InteropResponse(ltype.toArray(new String[0]));
|
} catch (Exception exception)
|
{
|
throw new SerializationException(Shared.getMessage(language, exception.getMessage()), exception);
|
}
|
}
|
}
|
