using System.Collections.Generic;
using System.Linq;
using Neo.Afx.ComponentModel;

namespace Neo.Afx.Admin.Integration
{
    ///<summary>
    /// Afx admin database
    ///</summary>
    public class AfxAdminIntegrationDatabase : Database<AfxAdminIntegrationContext>
    {
        ///<summary>
        /// Constructor
        ///</summary>
        public AfxAdminIntegrationDatabase()
            : base(new AfxAdminIntegrationContext(), 900000)
        {
        }

        #region GetConnections

        /// <summary>
        /// Get all data from table.
        /// </summary>
        /// <returns>List of objects</returns>
        public IEnumerable<Connection> GetConnections()
        {
            return (from item in Context.Connections
                    where !item.IsCancelled
                    select item).ToList();
        }

        /// <summary>
        /// Get data from table based on count.
        /// </summary>
        /// <param name="count">Restricts amount returned items in the collection.</param>
        /// <returns>List of objects.</returns>
        public IEnumerable<Connection> GetConnections(int count)
        {
            return (from item in Context.Connections
                    where item.IsCancelled == false
                    select item).Take(count).ToList();
        }

        #endregion

        #region GetConnectionTypes

        /// <summary>
        /// Get all data from table.
        /// </summary>
        /// <returns>List of objects</returns>
        public IEnumerable<ConnectionType> GetConnectionTypes()
        {
            return (from item in Context.ConnectionTypes
                    select item).ToList();
        }

        /// <summary>
        /// Get data from table based on count.
        /// </summary>
        /// <param name="count">Restricts amount returned items in the collection.</param>
        /// <returns>List of objects.</returns>
        public IEnumerable<ConnectionType> GetConnectionTypes(int count)
        {
            return (from item in Context.ConnectionTypes
                    select item).Take(count).ToList();
        }

        #endregion

        #region GetCommandTypes

        /// <summary>
        /// Get all data from table.
        /// </summary>
        /// <returns>List of objects</returns>
        public IEnumerable<CommandType> GetCommandTypes()
        {
            return (from item in Context.CommandTypes
                    select item).ToList();
        }

        /// <summary>
        /// Get data from table based on count.
        /// </summary>
        /// <param name="count">Restricts amount returned items in the collection.</param>
        /// <returns>List of objects.</returns>
        public IEnumerable<CommandType> GetCommandTypes(int count)
        {
            return (from item in Context.CommandTypes
                    select item).Take(count).ToList();
        }

        #endregion

        #region GetDataSources

        /// <summary>
        /// Get all data from table.
        /// </summary>
        /// <returns>List of objects</returns>
        public IEnumerable<DataSource> GetDataSources()
        {
            return (from item in Context.DataSources
                    select item).ToList();
        }

        /// <summary>
        /// Get data from table based on count.
        /// </summary>
        /// <param name="count">Restricts amount returned items in the collection.</param>
        /// <returns>List of objects.</returns>
        public IEnumerable<DataSource> GetDataSources(int count)
        {
            return (from item in Context.DataSources
                    select item).Take(count).ToList();
        }

        #endregion

        #region GetBulkReAssignMatrix
        /// <summary>
        /// Gets the bulk re assign matrix.
        /// </summary>
        /// <param name="systemIds">The system ids.</param>
        /// <param name="userId">The user id.</param>
        /// <param name="workflowId">The workflow id.</param>
        /// <param name="fromUserId">From user id.</param>
        /// <param name="toUserId">To user id.</param>
        /// <returns></returns>
        public IEnumerable<SystemBulkReAssignMatrixRecord> GetBulkReAssignMatrix(string systemIds, long userId, long workflowId, long fromUserId, long toUserId)
        {
            return Context.Pr_SystemBulkReAssignMatrixGet(systemIds, userId, workflowId, fromUserId, toUserId).ToList();
        }
        #endregion

        #region BulkReAssignTasksAndParticipants
        /// <summary>
        /// Bulks the re assign tasks and participants.
        /// </summary>
        /// <param name="systemIds">The system ids.</param>
        /// <param name="workflowId">The workflow id.</param>
        /// <param name="workflowTemplateStepId">The workflow template step id.</param>
        /// <param name="fromUserId">From user id.</param>
        /// <param name="toUserId">To user id.</param>
        /// <param name="comments">The comments.</param>
        public void BulkReAssignTasksAndParticipants(string systemIds, long workflowId, long workflowTemplateStepId, long fromUserId, long toUserId, string comments)
        {
            Context.Pr_SystemBulkReAssignTasksAndParticipants(systemIds, workflowId, workflowTemplateStepId, fromUserId, toUserId, comments);
        }
        #endregion

        #region SearchSystemWorkflowInstances
        /// <summary>
        /// Searches the system workflow instances.
        /// </summary>
        /// <param name="systemIds">The system ids.</param>
        /// <param name="searchedByUserId">The searched by user id.</param>
        /// <param name="reference">The reference.</param>
        /// <param name="useMinimumReqFieldsOnly">if set to <c>true</c> [use minimum req fields only].</param>
        /// <returns></returns>
        public IEnumerable<SystemWorkflowInstanceSearchRecord> SearchSystemWorkflowInstances(string systemIds, long searchedByUserId, string reference, bool useMinimumReqFieldsOnly)
        {
            if(useMinimumReqFieldsOnly)
            {
                return (from r in Context.Pr_SystemWorkflowInstanceSearcher(systemIds, searchedByUserId, reference)
                        select new SystemWorkflowInstanceSearchRecord
                        {
                            WorkflowInstanceStatusID = r.WorkflowInstanceStatusID,
                            WorkflowFriendlyName = r.WorkflowFriendlyName,
                            ReferenceNumber = r.ReferenceNumber,
                            ConsoleUrl = r.ConsoleUrl,
                            WorkflowTemplateStep = r.WorkflowTemplateStep,
                            WorkflowTemplateStepTitle = r.WorkflowTemplateStepTitle,
                            WorkflowInstanceStatus = r.WorkflowInstanceStatus,
                            IntegrationSystemID = r.IntegrationSystemID,
                            WorkflowInstanceID = r.WorkflowInstanceID,
                            IsWorkflowAdmin = r.IsWorkflowAdmin
                        }).Distinct(new SystemWorkflowInstanceSearchRecordComparer()).ToList();
            }
            else
            {
                return Context.Pr_SystemWorkflowInstanceSearcher(systemIds, searchedByUserId, reference).ToList();
            }
        }

        public class SystemWorkflowInstanceSearchRecordComparer : IEqualityComparer<SystemWorkflowInstanceSearchRecord>
        {

            public new bool Equals(SystemWorkflowInstanceSearchRecord abc, SystemWorkflowInstanceSearchRecord def)
            {
                return abc.WorkflowInstanceID == def.WorkflowInstanceID;
            }

            public int GetHashCode(SystemWorkflowInstanceSearchRecord obj)
            {
                string code = obj.WorkflowInstanceID.ToString();

                return code.GetHashCode();
            }
        }
        #endregion

        #region CancelSystemWorkflowInstances
        /// <summary>
        /// Cancels the system workflow instances.
        /// </summary>
        /// <param name="systemId">The system id.</param>
        /// <param name="workflowInstanceId">The workflow instance id.</param>
        /// <param name="cancelledByUserId">The cancelled by user id.</param>
        /// <param name="comments">The comments.</param>
        public void CancelSystemWorkflowInstances(long systemId, long workflowInstanceId, long cancelledByUserId, string comments)
        {
            Context.Pr_SystemWorkflowInstanceCancel(systemId.ToString(), workflowInstanceId, cancelledByUserId, comments);
        }
        #endregion
    }
}