using System; 
using System.Collections.Generic; 
using System.Data.Entity; 
using System.Linq; 
using System.Linq.Expressions; 
using System.Runtime.Serialization; 
using System.Security.Permissions; 
using System.ServiceModel; 
using System.Text; 
using CommonDistributed; 
using CommonServer; 
using DbMain; 
using PersonalServer; 
using SspMain; 
  
namespace MessageServer 
{ 
    [DataContract(Namespace = Wsns.Message)] 
    public class MessageTaskView 
    { 
        [DataMember] 
        public int? ID; 
  
        [DataMember] 
        public string ProjectStr; 
  
        [DataMember] 
        public string Subject; 
  
        [DataMember] 
        public string SenderPersStr; 
  
        [DataMember] 
        public string RecipientPersStr; 
  
        [DataMember] 
        public DateTime? CreateDate; 
  
        [DataMember] 
        public DateTime? ActivityDate; 
  
        [DataMember] 
        public DateTime? PlanCompleteDate; 
  
        [DataMember] 
        public string CurrentStateStr; 
  
        [DataMember] 
        public bool IsSenderMe; 
  
        [DataMember] 
        public bool IsRecipientMe; 
  
        [DataMember] 
        public bool CanChangeMessage; 
  
        [DataMember] 
        public bool MustReadMessage; 
  
        [DataMember] 
        public bool IsTaskNotReaded; 
  
        [DataMember] 
        public bool IsCommentNotReaded; 
  
        [DataMember] 
        public bool IsActive; 
  
        [DataMember] 
        public bool IsPlanCompleteDateExpired; 
  
        [DataMember] 
        public bool HasAttachment; 
    } 
  
    [DataContract(Namespace = Wsns.Message)] 
    public class MessageTaskDetail 
    { 
        // Постановка задачи 
  
        [DataMember] 
        public int? ID; 
  
        [DataMember] 
        public string SenderPersStr; 
  
        [DataMember] 
        public bool IsSenderMe; 
  
        [DataMember] 
        public DateTime? CreateDate;         
  
        [DataMember] 
        public DateTime? LastChangeDate; 
  
        [DataMember] 
        public string LastChangePersStr; 
  
        [DataMember] 
        public bool IsLastChangePersMe;         
  
        // Назначение         
  
        [DataMember] 
        public string ProjectStr; 
  
        [DataMember] 
        public string Subject;         
  
        [DataMember] 
        public string RecipientPersStr; 
  
        [DataMember] 
        public bool IsRecipientMe; 
  
        [DataMember] 
        public DateTime? RecipientReadDate; 
  
        // Выполнение 
  
        [DataMember] 
        public DateTime? PlanCompleteDate; 
  
        [DataMember] 
        public bool IsPlanCompleteDateExpired; 
  
        [DataMember] 
        public DateTime? ActivityDate; 
  
        [DataMember] 
        public string CurrentStateStr; 
  
        [DataMember] 
        public DateTime? CurrentStateDate; 
  
        // Задание 
  
        [DataMember] 
        public string ContentText; 
    } 
  
    [DataContract(Namespace = Wsns.Message)] 
    public class MessageTaskEdit 
    { 
        [DataMember] 
        public int? ID; 
  
        [DataMember] 
        public byte[] TaskTimeS; 
  
        [DataMember] 
        public byte[] MessageTimeS; 
  
        [DataMember] 
        public int? ProjectID; 
  
        [DataMember] 
        public int? RecipientPersID; 
  
        [DataMember] 
        public DateTime? PlanCompleteDate; 
  
        [DataMember] 
        public string Subject; 
  
        [DataMember] 
        public string ContentText; 
    } 
  
    [ServiceBehavior(InstanceContextMode = InstanceContextMode.PerCall)] 
    [ServiceContract(Namespace = Wsns.Message)] 
    public class SvcMessageTask 
    { 
        SvcMessageCore SvcMessageCore = new SvcMessageCore(); 
  
        #region MessageTaskView 
  
        IQueryable<MessageTaskView> GetMessageTaskView(IQueryable<message_task> source) 
        { 
            using (var sc = DbMainFactory.Scope) 
            { 
                return
                    from mt in source 
  
                    let m = mt.ID_Reference                     
                    let sender = m.SenderPersID_Reference 
                    let recipient = m.RecipientPersID_Reference 
                    let currentStateID = SvcMessageTaskCore.GetCurrentStateID.Invoke(mt) 
  
                    join currentState in sc.Content.message_taskStates on currentStateID equals currentState.ID 
  
                    select new MessageTaskView 
                    { 
                        ID = mt.ID,                         
                        ProjectStr = mt.ProjectID_Reference.Caption, 
                        Subject = mt.Subject, 
                        SenderPersStr = SvcPersonalCore.GetShortNameTN.Invoke(sender), 
                        RecipientPersStr = SvcPersonalCore.GetShortNameTN.Invoke(recipient), 
                        CreateDate = m.CreateDate, 
                        ActivityDate = SvcMessageTaskCore.GetActivityDate.Invoke(mt), 
                        PlanCompleteDate = mt.PlanCompleteDate, 
                        CurrentStateStr = currentState.Caption, 
                        IsSenderMe = SvcMessageCore.GetIsSenderMe.Invoke(m), 
                        IsRecipientMe = SvcMessageCore.GetIsRecipientMe.Invoke(m) ?? false, 
                        CanChangeMessage = SvcMessageCore.GetCanChangeMessage.Invoke(m), 
                        MustReadMessage = SvcMessageCore.GetMustReadMessage.Invoke(m) ?? false, 
                        IsTaskNotReaded = SvcMessageCore.GetIsNotReadedMessage.Invoke(m) ?? false, 
  
                        IsCommentNotReaded = 
                            ( 
                                from md in mt.message_comments_TaskID_Reference 
                                let mdm = md.ID_Reference 
                                where SvcMessageCore.GetIsNotReadedMessage.Invoke(mdm).Value 
                                select md 
                            ).Any(), 
  
                        IsActive = SvcMessageTaskCore.GetIsActive.Invoke(mt, currentState), 
  
                        IsPlanCompleteDateExpired = 
                            SvcMessageTaskCore.GetIsPlanCompleteDateExpired.Invoke(mt, currentState), 
  
                        HasAttachment = m.message_attachments_MsgID_Reference.Any() 
                    }; 
            } 
        } 
  
        [OperationContract] 
        public MessageTaskView[] GetMessageTaskViewByEfficientFilter 
        ( 
            int direction, // 0 - Все 1 - Входящие 2 - Исходящие 
            int category // 1 - Непрочитанные 2 - Активные 3 - Недавние 
        ) 
        { 
            if (direction < 0 || direction > 2) 
                throw new ArgumentException("direction"); 
  
            using (var sc = DbMainFactory.Scope) 
            { 
                var q = sc.Content.message_task.Take(0); 
  
                if (category == 1) 
                { 
                    #region Непрочитанные 
  
                    if (direction == 0 || direction == 1) 
                    { 
                        q = q.Concat( 
                            from mt in sc.Content.message_task 
                            let m = mt.ID_Reference 
                            where SvcMessageCore.GetIsNotReadedMessage.Invoke(m).Value 
                            select mt 
                        ); 
  
                        q = q.Concat( 
                            from mt in sc.Content.message_task 
                            let m = mt.ID_Reference 
                            where
                                SvcMessageCore.GetIsRecipientMe.Invoke(m).Value && 
                                ( 
                                    from md in mt.message_comments_TaskID_Reference 
                                    let mdm = md.ID_Reference 
                                    where SvcMessageCore.GetIsNotReadedMessage.Invoke(mdm).Value 
                                    select md 
                                ).Any() 
                            select mt 
                        ); 
                    } 
  
                    if (direction == 0 || direction == 2) 
                    { 
                        q = q.Concat( 
                            from mt in sc.Content.message_task 
                            let m = mt.ID_Reference 
                            where
                                SvcMessageCore.GetIsSenderMe.Invoke(m) && 
                                ( 
                                    from md in mt.message_comments_TaskID_Reference 
                                    let mdm = md.ID_Reference 
                                    where SvcMessageCore.GetIsNotReadedMessage.Invoke(mdm).Value 
                                    select md 
                                ).Any() 
                            select mt 
                        ); 
                    } 
  
                    if (direction == 0) 
                    { 
                        q = q.Concat( 
                            from mt in sc.Content.message_task 
                            where
                                ( 
                                    from md in mt.message_comments_TaskID_Reference 
                                    let mdm = md.ID_Reference 
                                    where SvcMessageCore.GetIsNotReadedMessage.Invoke(mdm).Value 
                                    select md 
                                ).Any() 
                            select mt 
                        ); 
                    } 
  
                    #endregion 
                } 
                else if (category == 2) 
                { 
                    #region Активные 
  
                    var protectDateFrom = DbDateTime.Now.AddDays(-365); 
  
                    if (direction == 0 || direction == 1) 
                    { 
                        q = q.Concat( 
                            from mt in sc.Content.message_task 
                            let m = mt.ID_Reference 
                            let currentStateID = SvcMessageTaskCore.GetCurrentStateID.Invoke(mt) 
                            join currentState in sc.Content.message_taskStates on currentStateID equals currentState.ID 
                            where
                                SvcMessageCore.GetIsRecipientMe.Invoke(m).Value && 
                                m.CreateDate >= protectDateFrom && 
                                SvcMessageTaskCore.GetIsActive.Invoke(mt, currentState) 
                            select mt 
                        ); 
                    } 
  
                    if (direction == 0 || direction == 2) 
                    { 
                        q = q.Concat( 
                            from mt in sc.Content.message_task 
                            let m = mt.ID_Reference 
                            let currentStateID = SvcMessageTaskCore.GetCurrentStateID.Invoke(mt) 
                            join currentState in sc.Content.message_taskStates on currentStateID equals currentState.ID 
                            where
                                SvcMessageCore.GetIsSenderMe.Invoke(m) && 
                                m.CreateDate >= protectDateFrom && 
                                SvcMessageTaskCore.GetIsActive.Invoke(mt, currentState) 
                            select mt 
                        ); 
                    } 
  
                    #endregion 
                } 
                else if (category == 3) 
                { 
                    #region Недавние 
  
                    var recentDateFrom = DbDateTime.Now.AddDays(-30); 
  
                    if (direction == 0 || direction == 1) 
                    { 
                        q = q.Concat( 
                            from mt in sc.Content.message_task 
                            let m = mt.ID_Reference 
                            where
                                SvcMessageCore.GetIsRecipientMe.Invoke(m).Value && 
                                m.CreateDate >= recentDateFrom 
                            select mt 
                        ); 
  
                        q = q.Concat( 
                            from mt in sc.Content.message_task 
                            let m = mt.ID_Reference 
                            where
                                SvcMessageCore.GetIsRecipientMe.Invoke(m).Value && 
                                ( 
                                    from md in mt.message_comments_TaskID_Reference 
                                    where md.ID_Reference.CreateDate >= recentDateFrom 
                                    select md 
                                ).Any() 
                            select mt 
                        ); 
                    } 
  
                    if (direction == 0 || direction == 2) 
                    { 
                        q = q.Concat( 
                            from mt in sc.Content.message_task 
                            let m = mt.ID_Reference 
                            where
                                SvcMessageCore.GetIsSenderMe.Invoke(m) && 
                                m.CreateDate >= recentDateFrom 
                            select mt 
                        ); 
  
                        q = q.Concat( 
                            from mt in sc.Content.message_task 
                            let m = mt.ID_Reference 
                            where
                                SvcMessageCore.GetIsSenderMe.Invoke(m) && 
                                ( 
                                    from md in mt.message_comments_TaskID_Reference 
                                    where md.ID_Reference.CreateDate >= recentDateFrom 
                                    select md 
                                ).Any() 
                            select mt 
                        ); 
                    } 
  
                    if (direction == 0) 
                    { 
                        q = q.Concat( 
                            from mt in sc.Content.message_task 
                            where
                                ( 
                                    from md in mt.message_comments_TaskID_Reference 
                                    let mdm = md.ID_Reference 
                                    where
                                        SvcMessageCore.GetIsSenderMe.Invoke(mdm) && 
                                        mdm.CreateDate >= recentDateFrom 
                                    select md 
                                ).Any() 
                            select mt 
                        ); 
  
                        q = q.Concat( 
                            from mt in sc.Content.message_task 
                            where
                                ( 
                                    from md in mt.message_comments_TaskID_Reference 
                                    let mdm = md.ID_Reference 
                                    where
                                        SvcMessageCore.GetIsRecipientMe.Invoke(mdm).Value && 
                                        mdm.CreateDate >= recentDateFrom 
                                    select md 
                                ).Any() 
                            select mt 
                        ); 
                    } 
  
                    #endregion 
                } 
                else
                    throw new ArgumentException("category"); 
  
                return GetMessageTaskView(q.Distinct()).ToArray(); 
            } 
        } 
  
        [OperationContract] 
        public MessageTaskView[] GetMessageTaskViewByFavID(int favID) 
        { 
            using (var sc = DbMainFactory.Scope) 
            { 
                var q = 
                    from mt in sc.Content.message_task 
                    from mtf in mt.message_taskToFavorite_TaskID_Reference 
                    where mtf.FavID == favID 
                    select mt; 
  
                return GetMessageTaskView(q).ToArray(); 
            } 
        } 
  
        [OperationContract] 
        public MessageTaskView GetMessageTaskViewByID(int id) 
        { 
            using (var sc = DbMainFactory.Scope) 
            { 
                var q = sc.Content.message_task.Where(mt => mt.ID == id); 
                return GetMessageTaskView(q).FirstOrDefault(); 
            } 
        } 
  
        [OperationContract] 
        public MessageTaskView[] GetMessageTaskViewByExtendedFilter 
        ( 
            DateTime t1, DateTime t2, int projectID,  
            int? senderPersID, int? recipientPersID, string subject, 
            int[] stateID 
        ) 
        { 
            if
            ( 
                string.IsNullOrWhiteSpace(subject) && 
                senderPersID.HasValue == false && 
                recipientPersID.HasValue == false
            ) 
                return null; 
  
            t1 = t1.Date; 
            t2 = t2.Date.AddDays(1); 
            stateID = stateID ?? new int[0]; 
  
            using (var sc = DbMainFactory.Scope) 
            { 
                var q = 
                    from mt in sc.Content.message_task 
                    let m = mt.ID_Reference 
                    let currentStateID = SvcMessageTaskCore.GetCurrentStateID.Invoke(mt) 
                    where m.CreateDate >= t1 && m.CreateDate < t2 && stateID.Contains(currentStateID.Value) 
                    select new { m, mt }; 
  
                if (senderPersID.HasValue) 
                    q = q.Where(s => s.m.SenderPersID == senderPersID); 
  
                if (recipientPersID.HasValue) 
                    q = q.Where(s => s.m.RecipientPersID == recipientPersID); 
  
                if (string.IsNullOrWhiteSpace(subject) == false) 
                    q = q.Where(s => s.mt.Subject.Contains(subject)); 
  
                if (projectID > 0) 
                    q = q.Where(s => s.mt.ProjectID == projectID); 
  
                return GetMessageTaskView(q.Select(s => s.mt)).ToArray(); 
            } 
        } 
  
        #endregion 
  
        #region MessageTaskDetail 
  
        [OperationContract] 
        public MessageTaskDetail GetMessageTaskDetailByID(int id) 
        { 
            using (var sc = DbMainFactory.Scope) 
            { 
                var q = 
                    from mt in sc.Content.message_task 
                    where mt.ID == id 
  
                    let m = mt.ID_Reference 
                    let sender = m.SenderPersID_Reference 
                    let recipient = m.RecipientPersID_Reference 
                    let lastChangePers = m.LastChangePersID_Reference 
                    let currentStateID = SvcMessageTaskCore.GetCurrentStateID.Invoke(mt) 
  
                    join currentState in sc.Content.message_taskStates on currentStateID equals currentState.ID 
  
                    select new MessageTaskDetail 
                    { 
                        ID = mt.ID, 
                        SenderPersStr = SvcPersonalCore.GetFullNameTN.Invoke(sender), 
                        IsSenderMe = SvcMessageCore.GetIsSenderMe.Invoke(m), 
                        CreateDate = m.CreateDate,                         
                        LastChangeDate = m.LastChangeDate, 
                        LastChangePersStr = SvcPersonalCore.GetFullNameTN.Invoke(lastChangePers), 
                        IsLastChangePersMe = SvcMessageCore.GetIsLastChangePersMe.Invoke(m) ?? false,                         
  
                        ProjectStr = mt.ProjectID_Reference.Caption, 
                        Subject = mt.Subject, 
                        RecipientPersStr = SvcPersonalCore.GetFullNameTN.Invoke(recipient), 
                        IsRecipientMe = SvcMessageCore.GetIsRecipientMe.Invoke(m) ?? false, 
                        RecipientReadDate = m.RecipientReadDate, 
  
                        PlanCompleteDate = mt.PlanCompleteDate, 
                        IsPlanCompleteDateExpired = SvcMessageTaskCore.GetIsPlanCompleteDateExpired.Invoke(mt, currentState), 
                        ActivityDate = SvcMessageTaskCore.GetActivityDate.Invoke(mt), 
                        CurrentStateStr = currentState.Caption, 
                        CurrentStateDate = SvcMessageTaskCore.GetCurrentStateDate.Invoke(mt), 
  
                        ContentText = m.ContentText 
                    }; 
  
                return q.First(); 
            } 
        } 
  
        [OperationContract] 
        public bool GetCanUserChangeTaskStateByID(int taskID) 
        { 
            using (var sc = DbMainFactory.Scope) 
            { 
                var task = 
                    ( 
                        from mt in sc.Content.message_task 
                        where mt.ID == taskID 
                        let m = mt.ID_Reference 
                        select new
                        { 
                            SenderPersID = m.SenderPersID, 
                            RecipientPersID = m.RecipientPersID 
                        } 
                    ) 
                    .First(); 
  
                var persID = UserContext.PersID; 
  
                return task.SenderPersID == persID || task.RecipientPersID == persID; 
            } 
        } 
  
        [OperationContract] 
        public ClassifierItem[] GetTaskFavoritesByID(int taskID) 
        { 
            using (var sc = DbMainFactory.Scope) 
            { 
                var q = 
                    from mtf in sc.Content.message_taskToFavorite 
                    let f = mtf.FavID_Reference 
                    where
                        mtf.TaskID == taskID && 
                        f.PersID == UserContext.PersID 
                    orderby f.Caption 
                    select new ClassifierItem 
                    { 
                        ID = f.ID, 
                        Caption = f.Caption 
                    }; 
  
                return q.ToArray(); 
            } 
        } 
  
        #endregion 
  
        #region MessageTaskEdit 
  
        [OperationContract] 
        public MessageTaskEdit GetMessageTaskEditNew() 
        { 
            return new MessageTaskEdit(); 
        } 
  
        [OperationContract] 
        public MessageTaskEdit GetMessageTaskEditByID(int id) 
        { 
            using (var sc = DbMainFactory.Scope) 
            { 
                var q = 
                    from mt in sc.Content.message_task 
                    where mt.ID == id 
                    let m = mt.ID_Reference 
                    select new MessageTaskEdit 
                    { 
                        ID = mt.ID, 
                        TaskTimeS = mt.TimeS, 
                        MessageTimeS = m.TimeS, 
                        ProjectID = mt.ProjectID, 
                        RecipientPersID = m.RecipientPersID, 
                        PlanCompleteDate = mt.PlanCompleteDate, 
                        Subject = mt.Subject, 
                        ContentText = m.ContentText 
                    }; 
  
                return q.First(); 
            } 
        } 
  
        [OperationContract] 
        [PrincipalPermission(SecurityAction.Demand, Role = Roles.message_task)] 
        public int SaveMessageTask(MessageTaskEdit item, UpdateAction action) 
        { 
            using (var sc = DbMainFactory.Scope) 
            { 
                message message; 
                message_task message_task; 
  
                if (action == UpdateAction.Insert) 
                { 
                    message = SvcMessageCore.CreateMessage(); 
                    sc.Content.AttachAsAdded(message); 
                    message.ID = -1; 
  
                    message_task = new message_task(); 
                    sc.Content.AttachAsAdded(message_task); 
                    message_task.ID = message.ID; 
                } 
                else
                { 
                    SvcMessageCore.ValidateCanChangeMessageByID(item.ID.Value); 
  
                    message = sc.Content.message.Where(m => m.ID == item.ID).First(); 
                    message_task = sc.Content.message_task.Where(mt => mt.ID == item.ID).First(); 
  
                    var messageTimeS = sc.Content.Entry(message).Property(v => v.TimeS); 
                    messageTimeS.OriginalValue = item.MessageTimeS; 
                    messageTimeS.CurrentValue = item.MessageTimeS; 
  
                    var taskTimeS = sc.Content.Entry(message_task).Property(v => v.TimeS); 
                    taskTimeS.OriginalValue = item.TaskTimeS; 
                    taskTimeS.CurrentValue = item.TaskTimeS; 
  
                    SvcMessageCore.SetMessageChanged(message); 
                } 
  
                message.RecipientPersID = item.RecipientPersID; 
                message.ContentText = item.ContentText; 
                message_task.ProjectID = item.ProjectID; 
                message_task.PlanCompleteDate = item.PlanCompleteDate; 
                message_task.Subject = item.Subject; 
  
                sc.Content.SaveChanges(); 
                return message.ID.Value; 
            } 
        } 
  
        [OperationContract] 
        [PrincipalPermission(SecurityAction.Demand, Role = Roles.message_task_delete)] 
        public void DeleteMessageTaskByID(int id) 
        { 
            using (var sc = DbMainFactory.Scope) 
            using (new DbContextNoDetectChangesScope(sc.Content)) 
            { 
                SvcMessageCore.ValidateCanChangeMessageByID(id); 
  
                var qDeleteData = 
                    from mt in sc.Content.message_task 
                    where mt.ID == id 
                    select new
                    { 
                        Task = mt, 
                        TaskMessage = mt.ID_Reference, 
                        Comments = 
                            from comment in mt.message_comments_TaskID_Reference 
                            select new
                            { 
                                Comment = comment, 
                                CommentMessage = comment.ID_Reference 
                            }, 
                        Favorites = mt.message_taskToFavorite_TaskID_Reference 
                    }; 
  
                var deleteData = qDeleteData.First(); 
  
                sc.Content.AttachManyAsDeleted(deleteData.Comments.Select(d => d.Comment)); 
                sc.Content.AttachManyAsDeleted(deleteData.Comments.Select(d => d.CommentMessage)); 
                sc.Content.AttachManyAsDeleted(deleteData.Favorites); 
                sc.Content.AttachAsDeleted(deleteData.Task); 
                sc.Content.AttachAsDeleted(deleteData.TaskMessage); 
  
                sc.Content.SaveChanges(); 
            } 
        } 
  
        #endregion 
  
        #region Nsi 
  
        [OperationContract] 
        public ClassifierItem[] GetMessageTaskProjects() 
        { 
            using (var sc = DbMainFactory.Scope) 
                return sc.Content.projects 
                    .Select(p => new ClassifierItem { ID = p.ID, Caption = p.Caption }) 
                    .OrderBy(p => p.Caption) 
                    .ToArray(); 
        } 
  
        [OperationContract] 
        public ClassifierItem[] GetMessageTaskAllStates() 
        { 
            using (var sc = DbMainFactory.Scope) 
                return sc.Content.message_taskStates 
                    .Select(p => new ClassifierItem { ID = p.ID, Caption = p.Caption }) 
                    .OrderBy(p => p.ID) 
                    .ToArray(); 
        } 
  
        #endregion 
    } 
}