/*
 *
 * (c) Copyright Ascensio System Limited 2010-2018
 *
 * This program is freeware. You can redistribute it and/or modify it under the terms of the GNU 
 * General Public License (GPL) version 3 as published by the Free Software Foundation (https://www.gnu.org/copyleft/gpl.html). 
 * In accordance with Section 7(a) of the GNU GPL its Section 15 shall be amended to the effect that 
 * Ascensio System SIA expressly excludes the warranty of non-infringement of any third-party rights.
 *
 * THIS PROGRAM IS DISTRIBUTED WITHOUT ANY WARRANTY; WITHOUT EVEN THE IMPLIED WARRANTY OF MERCHANTABILITY OR
 * FITNESS FOR A PARTICULAR PURPOSE. For more details, see GNU GPL at https://www.gnu.org/copyleft/gpl.html
 *
 * You can contact Ascensio System SIA by email at sales@onlyoffice.com
 *
 * The interactive user interfaces in modified source and object code versions of ONLYOFFICE must display 
 * Appropriate Legal Notices, as required under Section 5 of the GNU GPL version 3.
 *
 * Pursuant to Section 7 § 3(b) of the GNU GPL you must retain the original ONLYOFFICE logo which contains 
 * relevant author attributions when distributing the software. If the display of the logo in its graphic 
 * form is not reasonably feasible for technical reasons, you must include the words "Powered by ONLYOFFICE" 
 * in every copy of the program you distribute. 
 * Pursuant to Section 7 § 3(e) we decline to grant you any rights under trademark law for use of our trademarks.
 *
*/


using System;
using System.Collections.Generic;
using System.Linq;

using ASC.Common;
using ASC.Common.Logging;
using ASC.Common.Threading;
using ASC.Core;
using ASC.Core.Tenants;
using ASC.CRM.Core;
using ASC.CRM.Core.Dao;
using ASC.CRM.Core.Entities;
using ASC.CRM.Core.Enums;
using ASC.CRM.Resources;
using ASC.VoipService;
using ASC.VoipService.Dao;

using Microsoft.Extensions.Options;

namespace ASC.Web.CRM.Classes
{
    [Scope]
    public class VoipEngine
    {
        private readonly DistributedTaskQueue _queue;

        public readonly DaoFactory _daoFactory;
        public readonly VoipDao _voipDao;
        public readonly TenantManager _tenantManager;
        public readonly ILog _logger;
        public readonly int _tenantId;
        public readonly SecurityContext _securityContext;
        public readonly TenantUtil _tenantUtil;
        public readonly CrmSecurity _crmSecurity;

        private readonly object Locker = new object();

        public VoipEngine(DaoFactory daoFactory,
                         CrmSecurity crmSecurity,
                         TenantUtil tenantUtil,
                         DistributedTaskQueueOptionsManager optionsManager,
                         SecurityContext securityContext,
                         IOptionsMonitor<ILog> logger,
                         TenantManager tenantManager,
                         VoipDao voipDao)
        {
            _crmSecurity = crmSecurity;
            _tenantUtil = tenantUtil;
            _securityContext = securityContext;
            _queue = optionsManager.Get<QueueItem>();
            _logger = logger.Get("ASC.CRM");
            _tenantManager = tenantManager;
            _voipDao = voipDao;
            _daoFactory = daoFactory;
        }


        public VoipCall SaveOrUpdateCall(VoipCall callHistory)
        {
            var dao = _daoFactory.GetVoipDao();
            var call = dao.GetCall(callHistory.Id) ?? callHistory;

            if (string.IsNullOrEmpty(call.ParentID))
            {
                GetContact(call);
            }

            if (!callHistory.AnsweredBy.Equals(Guid.Empty))
            {
                call.AnsweredBy = callHistory.AnsweredBy;
            }

            if (!callHistory.Date.Equals(default(DateTime)))
            {
                call.Date = callHistory.Date;
            }

            if (!callHistory.EndDialDate.Equals(default(DateTime)))
            {
                call.EndDialDate = callHistory.EndDialDate;
            }

            if (call.Price == 0 && callHistory.Price != default(decimal))
            {
                call.Price = callHistory.Price;
            }

            if (call.DialDuration == 0)
            {
                call.DialDuration = callHistory.DialDuration;
            }

            if (call.VoipRecord == null)
            {
                call.VoipRecord = new VoipRecord();
            }

            if (string.IsNullOrEmpty(call.VoipRecord.Id))
            {
                call.VoipRecord.Id = callHistory.VoipRecord.Id;
            }

            if (call.VoipRecord.Price == default(decimal))
            {
                call.VoipRecord.Price = callHistory.VoipRecord.Price;
            }

            if (string.IsNullOrEmpty(call.VoipRecord.Uri))
            {
                call.VoipRecord.Uri = callHistory.VoipRecord.Uri;
            }

            if (call.VoipRecord.Duration == 0)
            {
                call.VoipRecord.Duration = callHistory.VoipRecord.Duration;
            }

            if (callHistory.Status.HasValue)
            {
                call.Status = callHistory.Status;
            }

            return dao.SaveOrUpdateCall(call);
        }

        public void AddHistoryToCallContact(VoipCall call, DaoFactory daoFactory)
        {
            var listItemDao = daoFactory.GetListItemDao();

            if (call == null || call.ContactId == 0) return;

            var category = listItemDao.GetByTitle(ListType.HistoryCategory, CRMCommonResource.HistoryCategory_Call);
            if (category == null)
            {
                category = new ListItem(CRMCommonResource.HistoryCategory_Call, "event_category_call.png");
                category.ID = listItemDao.CreateItem(ListType.HistoryCategory, category);
            }

            var contact = daoFactory.GetContactDao().GetByID(call.ContactId);

            if (contact != null && _crmSecurity.CanAccessTo(contact))
            {
                var note = call.Status == VoipCallStatus.Incoming || call.Status == VoipCallStatus.Answered
                    ? CRMContactResource.HistoryVoipIncomingNote
                    : CRMContactResource.HistoryVoipOutcomingNote;
                var content = string.Format(note, call.DialDuration);

                var relationshipEvent = new RelationshipEvent
                {
                    CategoryID = category.ID,
                    EntityType = EntityType.Any,
                    EntityID = 0,
                    Content = content,
                    ContactID = contact.ID,
                    CreateOn = _tenantUtil.DateTimeFromUtc(DateTime.UtcNow),
                    CreateBy = _securityContext.CurrentAccount.ID
                };

                daoFactory.GetRelationshipEventDao().CreateItem(relationshipEvent);
            }
        }

        public Contact GetContact(VoipCall call)
        {
            if (call.ContactId != 0)
            {
                return null;
            }

            var contactPhone = call.Status == VoipCallStatus.Incoming || call.Status == VoipCallStatus.Answered ? call.From : call.To;

            var newContactIds = _daoFactory.GetContactDao().GetContactIDsByContactInfo(ContactInfoType.Phone, contactPhone.TrimStart('+'), null, true);

            foreach (var newContactId in newContactIds)
            {
                if (newContactId != 0)
                {
                    var existContact = _daoFactory.GetContactDao().GetByID(newContactId);
                    if (_crmSecurity.CanAccessTo(existContact))
                    {
                        call.ContactId = newContactId;
                        return existContact;
                    }
                }
            }

            return null;
        }

        public List<Contact> GetContacts(string contactPhone, DaoFactory daoFactory)
        {
            var dao = daoFactory.GetContactDao();
            var ids = dao.GetContactIDsByContactInfo(ContactInfoType.Phone, contactPhone.TrimStart('+'), null, true);
            return ids.Select(r => dao.GetByID(r)).ToList();
        }

        public void SaveAdditionalInfo(string callId)
        {
            lock (Locker)
            {
                var _queueItem = new QueueItem { CallID = callId, TenantID = _tenantId };

                _queue.QueueTask((a, b) => SaveAdditionalInfoAction(_queueItem), _queueItem); ;
            }
        }

        private void SaveAdditionalInfoAction(QueueItem queueItem)
        {
            try
            {
                _tenantManager.SetCurrentTenant(queueItem.TenantID);

                var voipEngine = new VoipEngine(_daoFactory,
                                                _crmSecurity,
                                                _tenantUtil,
                                                null,
                                                _securityContext,
                                                null,
                                                _tenantManager,
                                                _voipDao);

                var dao = _daoFactory.GetVoipDao();

                var call = dao.GetCall(queueItem.CallID);

                GetPriceAndDuration(call);

                if (call.ChildCalls.Any())
                {
                    call.ChildCalls.ForEach(r =>
                    {
                        GetPriceAndDuration(r);
                        voipEngine.SaveOrUpdateCall(r);
                    });
                }

                call = voipEngine.SaveOrUpdateCall(call);

                if (!string.IsNullOrEmpty(call.VoipRecord.Id))
                {
                    call.VoipRecord = _voipDao.GetProvider().GetRecord((string)call.Id, (string)call.VoipRecord.Id);
                    voipEngine.SaveOrUpdateCall(call);
                }

                _securityContext.AuthenticateMe(call.AnsweredBy);
                AddHistoryToCallContact(call, _daoFactory);

            }
            catch (Exception ex)
            {
                _logger.ErrorFormat("SaveAdditionalInfo {0}, {1}", ex, ex.StackTrace);
            }
        }

        private void GetPriceAndDuration(VoipCall call)
        {
            var provider = _voipDao.GetProvider();
            var twilioCall = provider.GetCall(call.Id);

            call.Price = twilioCall.Price;
            call.DialDuration = twilioCall.DialDuration;
        }

        public void AnswerCall(VoipCall call)
        {
            call.AnsweredBy = _securityContext.CurrentAccount.ID;
            call.Status = VoipCallStatus.Answered;

            _daoFactory.GetVoipDao().SaveOrUpdateCall(call);
        }

        public Contact CreateContact(string contactPhone)
        {
            var contact = new Person
            {
                FirstName = contactPhone,
                LastName = _tenantUtil.DateTimeFromUtc(DateTime.UtcNow).ToString("yyyy-MM-dd hh:mm"),
                ShareType = ShareType.None,
                CreateBy = _securityContext.CurrentAccount.ID,
                CreateOn = DateTime.UtcNow
            };

            contact.ID = _daoFactory.GetContactDao().SaveContact(contact);

            _daoFactory.GetContactInfoDao()
                .Save(new ContactInfo
                {
                    ContactID = contact.ID,
                    IsPrimary = true,
                    InfoType = ContactInfoType.Phone,
                    Data = contactPhone
                });

            _crmSecurity.SetAccessTo(contact, new List<Guid> { _securityContext.CurrentAccount.ID });

            return contact;
        }

        private class QueueItem : DistributedTask
        {
            public int TenantID { get; set; }
            public string CallID { get; set; }
        }
    }
}