package art.servers.transactionsserver.model.objects;

import art.library.interop.InteropParameters;
import art.library.interop.InteropResponse;
import art.library.interop.serialization.SerializationException;
import art.library.model.transactions.scheduler.ScheduledTask;
import art.library.model.transactions.scheduler.ScheduledTaskProcedureInterval;
import art.library.persistence.Persistence;
import static art.servers.controller.ListenerImplementation.getTimestamp;
import art.servers.transactionsserver.Shared;
import java.lang.reflect.Field;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.logging.Level;
import java.util.logging.Logger;
import java.util.stream.Collectors;

public class ModelCrudObject
{
    public ModelCrudObject()
    {
    }

    /**
     * 
     * @param parameters
     * String language
     * String classname
     * @return
     * @throws SerializationException 
     */
    @SuppressWarnings("unchecked")
    public InteropResponse getObjectsFolders(InteropParameters parameters) throws SerializationException
    {
        String language = parameters.hasParameter("language") ? (String) parameters.getParameterValue("language") : art.servers.Shared.getLanguage();
        Set<String> lfolder = new HashSet<>();
        
        try
        {   
            String classname = (parameters.hasParameter("classname") == true) ? (String) parameters.getParameterValue("classname") : null;
            List<Object> lobject = Shared.controllerDatabase.getTimelessPersistance().get(0).getObject(classname);
            
            lfolder = lobject.stream().map(o -> (String) getValue(o, "folder")).collect(Collectors.toSet());

            return new InteropResponse(lfolder.toArray(new String[0]));
        } catch (Exception exception)
        {
            throw new SerializationException(Shared.getMessage(language, exception.getMessage()), exception);
        }
    }    
    
    /**
     * 
     * @param parameters
     * String language
     * String classname
     * String folder
     * String name
     * Empty  name_like/null
     * @return
     * @throws SerializationException 
     */
    @SuppressWarnings("unchecked")
    public InteropResponse getObjects(InteropParameters parameters) throws SerializationException
    {
        String language = parameters.hasParameter("language") ? (String) parameters.getParameterValue("language") : art.servers.Shared.getLanguage();
        List lobject = new ArrayList<>();
        
        try
        {
            String classname = (parameters.hasParameter("classname") == true) ? (String) parameters.getParameterValue("classname") : null;
            String folder = (parameters.hasParameter("folder") == true) ? ((String) parameters.getParameterValue("folder")).replace("'", "''") : null;
            boolean FOLDER_LIKE = parameters.hasParameter("folder_like");
            String name = (parameters.hasParameter("name") == true) ? ((String) parameters.getParameterValue("name")).replace("'", "''") : null;
            boolean NAME_LIKE = parameters.hasParameter("name_like");
            boolean SUMMARY = parameters.hasParameter("summary");
            long from = parameters.hasParameter("from") ? getTimestamp(parameters.getParameterValue("from")) : 0L;
            long to = parameters.hasParameter("to") ? getTimestamp(parameters.getParameterValue("to")) : System.currentTimeMillis();

            String where = "true";
            if (folder != null || name != null)
            {
                if ((folder != null) && (!folder.isEmpty()))
                {
                    if (FOLDER_LIKE) where += " and (folder='" + folder + "' or folder like '" + folder + "/%')";
                    else where += " and folder='" + folder + "'";
                }
                if (name != null)
                {
                    if (NAME_LIKE) where += " and name like '%" + name + "%'";
                    else where += " and name='" + name + "'";
                }
                
                if (SUMMARY) lobject = Shared.controllerDatabase.getTimelessPersistance().get(0).getObjectSummary(classname, where);
                else lobject = Shared.controllerDatabase.getTimelessPersistance().get(0).getObject(classname, where);
            } else
            {
                if (SUMMARY) lobject = Shared.controllerDatabase.getTimelessPersistance().get(0).getObjectSummary(classname);
                else lobject = Shared.controllerDatabase.getTimelessPersistance().get(0).getObject(classname);
            }            

            return new InteropResponse(lobject.toArray(new Object[0]));
        } catch (Exception exception)
        {
            exception.printStackTrace();
            throw new SerializationException(Shared.getMessage(language, exception.getMessage()), exception);
        }
    }
    
    /**
     * 
     * @param parameters
     * String language
     * String classname
     * String folder
     * String name
     * Empty  name_like/null
     * @return
     * @throws SerializationException 
     */
    @SuppressWarnings("unchecked")
    public InteropResponse getScheduledTasks(InteropParameters parameters) throws SerializationException
    {
        String language = parameters.hasParameter("language") ? (String) parameters.getParameterValue("language") : art.servers.Shared.getLanguage();
        List<Object> lobject = new ArrayList<Object>();

        try
        {   
            String folder = (parameters.hasParameter("folder") == true) ? (String) parameters.getParameterValue("folder") : null;
            boolean FOLDER_LIKE = parameters.hasParameter("folder_like");
            String name = (parameters.hasParameter("name") == true) ? (String)parameters.getParameterValue("name") : null;
            boolean NAME_LIKE = parameters.hasParameter("name_like");
            boolean SUMMARY = parameters.hasParameter("summary");
            long from = parameters.hasParameter("from") ? getTimestamp(parameters.getParameterValue("from")) : 0L;
            long to = parameters.hasParameter("to") ? getTimestamp(parameters.getParameterValue("to")) : System.currentTimeMillis();

            String where = "true";
            if (folder != null || name != null)
            {
                if ((folder != null) && (!folder.isEmpty()))
                {
                    if (FOLDER_LIKE) where += " and (folder='" + folder + "' or folder like '" + folder + "/%')";
                    else where += " and folder='" + folder + "'";
                }
                if (name != null)
                {
                    if (NAME_LIKE) where += " and name like '%" + name + "%'";
                    else where += " and name='" + name + "'";
                }

                if (SUMMARY) lobject = Shared.controllerDatabase.getTimelessPersistance().get(0).getObjectSummary(ScheduledTask.class.getName(), where);
                else lobject = Shared.controllerDatabase.getTimelessPersistance().get(0).getObject(ScheduledTask.class.getName(), where);
            } else
            {
                if (SUMMARY) lobject = Shared.controllerDatabase.getTimelessPersistance().get(0).getObjectSummary(ScheduledTask.class.getName());
                else lobject = Shared.controllerDatabase.getTimelessPersistance().get(0).getObject(ScheduledTask.class.getName());
            }            

            List<ScheduledTask> lresult = new ArrayList<ScheduledTask>();

            for (Object object : lobject)
            {
                ScheduledTask task = (ScheduledTask)object;
                if (task.scheduledTask.specificTimestamp > 0)
                {
                    if ((from <= task.scheduledTask.specificTimestamp) && (task.scheduledTask.specificTimestamp <= to))
                    {
                        lresult.add(task);
                    }
                }
                else
                {
                    if (task.scheduledTask != null)
                    {
                        if ((task.scheduledTask.weekly != null) && (task.scheduledTask.weekly.size() > 0))
                        {
                            for (ScheduledTaskProcedureInterval weekly : task.scheduledTask.weekly)
                            {
                                if (((from <= weekly.from) && (weekly.from <= to))
                                        &&
                                    ((from <= weekly.to) && (weekly.to <= to)))
                                {
                                    lresult.add(task);
                                    break;
                                }
                            }
                        }
                        else
                        {
                            ScheduledTaskProcedureInterval interval = null;
                            if (task.scheduledTask.interval != null) interval = task.scheduledTask.interval;
                            if (task.scheduledTask.monthly != null) interval = task.scheduledTask.monthly;

                            if (interval != null)
                            {
                                if (((from <= interval.from) && (interval.from <= to))
                                        &&
                                    ((from <= interval.to) && (interval.to <= to)))
                                {
                                    lresult.add(task);
                                }
                            }
                        }
                    }
                }
            }

            return new InteropResponse(lresult.toArray(new ScheduledTask[0]));
        } catch (Exception exception)
        {
            throw new SerializationException(Shared.getMessage(language, exception.getMessage()), exception);
        }
    }
    
    /**
     * 
     * @param parameters
     * String language
     * BodyContent Object[].class
     * @return
     * @throws SerializationException 
     */
    public InteropResponse addObject(InteropParameters parameters) throws SerializationException
    {
        String language = parameters.hasParameter("language") ? (String) parameters.getParameterValue("language") : art.servers.Shared.getLanguage();
        AtomicBoolean success = new AtomicBoolean(true);

        try
        {
            String classname = (parameters.hasParameter("classname") == true) ? (String) parameters.getParameterValue("classname") : null;
            if (classname.contains("[L"))
            {
                Object lobject[] = parameters.getBodyContentValue(classname);
                Arrays.stream(lobject).forEach(o ->
                {
                    try
                    {
                        addObject(language, o);
                    } catch (Exception ex)
                    {
                        success.set(false);
                        Logger.getLogger(ModelCrudObject.class.getName()).log(Level.SEVERE, null, ex);
                    }
                });
            } else
            {
                addObject(language, parameters.getBodyContentValue(classname));
            }
        }
        catch (Exception exception)
        {
            throw new SerializationException(Shared.getMessage(language, exception.getMessage()), exception);
        }
        return new InteropResponse(new Boolean(success.get()));
    }
    
    public InteropResponse addHistoricalObject(InteropParameters parameters) throws SerializationException
    {
        String language = parameters.hasParameter("language") ? (String) parameters.getParameterValue("language") : art.servers.Shared.getLanguage();
        AtomicBoolean success = new AtomicBoolean(true);

        try
        {
            String classname = (parameters.hasParameter("classname") == true) ? (String) parameters.getParameterValue("classname") : null;
            addHistoricalObject(language, parameters.getBodyContentValue(classname));
        }
        catch (Exception exception)
        {
            throw new SerializationException(Shared.getMessage(language, exception.getMessage()), exception);
        }
        return new InteropResponse(new Boolean(success.get()));
    }

    private void addObject(String language, Object o) throws Exception
    {
        try
        {
            if (getValue(o, "folder") == null)
            {
                setValue(o, "folder", "");
            }
            Shared.controllerDatabase.getTimelessPersistance().get(0).updateOrAddObject(o);
        } catch (Exception exception)
        {
            throw new SerializationException(Shared.getMessage(language, exception.getMessage()), exception);
        }
    }
    
    
    private void addHistoricalObject(String language, Object o) throws Exception
    {
        try
        {
            Shared.controllerDatabase.getHistoricalPersistance().get(0).updateOrAddObject(o);
        }
        catch (Exception exception)
        {
            throw new SerializationException(Shared.getMessage(language, exception.getMessage()), exception);
        }
    }

    /**
     * 
     * @param parameters
     * String language
     * BodyContent Object[].class
     * @return
     * @throws SerializationException 
     */
    public InteropResponse removeObject(InteropParameters parameters) throws SerializationException
    {
        String language = parameters.hasParameter("language") ? (String) parameters.getParameterValue("language") : art.servers.Shared.getLanguage();
         AtomicBoolean success = new AtomicBoolean(true);

        try
        {
            String classname = (parameters.hasParameter("classname") == true) ? (String) parameters.getParameterValue("classname") : null;
            Object lobject[] = parameters.getBodyContentValue(classname);
            
            Arrays.stream(lobject).forEach(o ->
            {
                try
                {
                    if (getValue(o, "folder") == null) setValue(o, "folder", "");
                    Shared.controllerDatabase.getTimelessPersistance().get(0).deleteObject(o);
                } catch (Exception ex)
                {
                    success.set(false);
                    ex.printStackTrace();
                }
            });
        } catch (Exception exception)
        {
            throw new SerializationException(art.servers.Shared.getMessage(language, exception.getMessage()), exception);
        }
        return new InteropResponse(new Boolean(success.get()));
    }
        

        

    
    /**
     * 
     * @param parameters
     * String language
     * String classname
     * String previousFolder
     * String newFolder
     * @return
     * @throws SerializationException 
     */
    @SuppressWarnings("unchecked")
    public InteropResponse renameObjectFolder(InteropParameters parameters) throws SerializationException
    {
        String language = parameters.hasParameter("language") ? (String) parameters.getParameterValue("language") : art.servers.Shared.getLanguage();
        boolean success = true;
        try
        {   
            String classname = (parameters.hasParameter("classname") == true) ? (String) parameters.getParameterValue("classname") : null;
            String previousFolder = ((parameters.hasParameter("previousFolder") == true) && !((String) parameters.getParameterValue("previousFolder")).isEmpty())
                    ? (String) parameters.getParameterValue("previousFolder") : "";
            String newFolder = ((parameters.hasParameter("newFolder") == true) && !((String) parameters.getParameterValue("newFolder")).isEmpty())
                    ? (String) parameters.getParameterValue("newFolder") : "";
                                    
            String where = "(folder = '" + previousFolder + "' or folder like '" + previousFolder + "/%')";
            List<Object> lobject = (List<Object>) (List<?>) Shared.controllerDatabase.getTimelessPersistance().get(0).getObject(classname, where);
                        
            for (Object object : lobject)
            {
                try
                {
                    Shared.controllerDatabase.getTimelessPersistance().get(0).deleteObject(object);
                    setValue(object, "folder", newFolder);
                    Shared.controllerDatabase.getTimelessPersistance().get(0).addObject_asynchronous(object);
                } catch (Exception e)
                {
                    success = false;
                }
            }
            return new InteropResponse(success);
        } catch (Exception exception)
        {
            throw new SerializationException(Shared.getMessage(language, exception.getMessage()), exception);
        }
    }
    
    private void setValue(Object object, String field, String value)
    {
        try
        {
            Field folderField = object.getClass().getDeclaredField(field);
            folderField.set(object, value);
        } catch (Exception e)
        {
            e.printStackTrace();
        }
    }
    
    private Object getValue(Object object, String field)
    {
        try
        {
            Field folderField = object.getClass().getDeclaredField(field);
            return folderField.get(object);
        } catch (Exception e)
        {
            e.printStackTrace();
        }
        return new Object();
    }
}