// (c) Copyright Ascensio System SIA 2010-2022 // // This program is a free software product. // You can redistribute it and/or modify it under the terms // of the GNU Affero General Public License (AGPL) version 3 as published by the Free Software // Foundation. In accordance with Section 7(a) of the GNU AGPL 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 details, see // the GNU AGPL at: http://www.gnu.org/licenses/agpl-3.0.html // // You can contact Ascensio System SIA at Lubanas st. 125a-25, Riga, Latvia, EU, LV-1021. // // The interactive user interfaces in modified source and object code versions of the Program must // display Appropriate Legal Notices, as required under Section 5 of the GNU AGPL version 3. // // Pursuant to Section 7(b) of the License you must retain the original Product logo when // distributing the program. Pursuant to Section 7(e) we decline to grant you any rights under // trademark law for use of our trademarks. // // All the Product's GUI elements, including illustrations and icon sets, as well as technical writing // content are licensed under the terms of the Creative Commons Attribution-ShareAlike 4.0 // International. See the License terms at http://creativecommons.org/licenses/by-sa/4.0/legalcode namespace ASC.Core.Billing; [Singletone] public class TariffServiceStorage { public ICache Cache { get; } internal readonly ICacheNotify Notify; public TariffServiceStorage(ICacheNotify notify, ICache cache) { Cache = cache; Notify = notify; Notify.Subscribe((i) => { Cache.Remove(TariffService.GetTariffCacheKey(i.TenantId)); Cache.Remove(TariffService.GetBillingUrlCacheKey(i.TenantId)); Cache.Remove(TariffService.GetBillingPaymentCacheKey(i.TenantId)); // clear all payments }, CacheNotifyAction.Remove); //TODO: Change code of WCF -> not supported in .NET standard/.Net Core /*try { var section = (ClientSection)ConfigurationManager.GetSection("system.serviceModel/client"); if (section != null) { billingConfigured = section.Endpoints.Cast() .Any(e => e.Contract == typeof(IService).FullName); } } catch (Exception err) { log.Error(err); }*/ } } public class TariffService : ITariffService { private const int DefaultTrialPeriod = 30; private static readonly TimeSpan _defaultCacheExpiration = TimeSpan.FromMinutes(5); private static readonly TimeSpan _standaloneCacheExpiration = TimeSpan.FromMinutes(15); private readonly ICache _cache; private readonly ICacheNotify _notify; private readonly ILogger _logger; private readonly IQuotaService _quotaService; private readonly ITenantService _tenantService; private readonly IUserService _userService; private readonly int _paymentDelay; private TimeSpan _cacheExpiration; private readonly CoreBaseSettings _coreBaseSettings; private readonly CoreSettings _coreSettings; private readonly IDbContextFactory _dbContextFactory; private readonly TariffServiceStorage _tariffServiceStorage; private readonly BillingClient _billingClient; private readonly IServiceProvider _serviceProvider; //private readonly int _activeUsersMin; //private readonly int _activeUsersMax; public TariffService() { _cacheExpiration = _defaultCacheExpiration; } public TariffService( IQuotaService quotaService, ITenantService tenantService, IUserService userService, CoreBaseSettings coreBaseSettings, CoreSettings coreSettings, IConfiguration configuration, IDbContextFactory coreDbContextManager, TariffServiceStorage tariffServiceStorage, ILogger logger, BillingClient billingClient, IServiceProvider serviceProvider) : this() { _logger = logger; _quotaService = quotaService; _tenantService = tenantService; _userService = userService; _coreSettings = coreSettings; _tariffServiceStorage = tariffServiceStorage; _billingClient = billingClient; _serviceProvider = serviceProvider; _coreBaseSettings = coreBaseSettings; _paymentDelay = configuration.GetSection("core:payment").Get().Delay; _cache = _tariffServiceStorage.Cache; _notify = _tariffServiceStorage.Notify; _dbContextFactory = coreDbContextManager; //var range = (_configuration["core.payment-user-range"] ?? "").Split('-'); //if (!int.TryParse(range[0], out _activeUsersMin)) //{ // _activeUsersMin = 0; //} //if (range.Length < 2 || !int.TryParse(range[1], out _activeUsersMax)) //{ // _activeUsersMax = constants.MaxEveryoneCount; //} } public Tariff GetTariff(int tenantId, bool withRequestToPaymentSystem = true) { //single tariff for all portals if (_coreBaseSettings.Standalone) { tenantId = -1; } var key = GetTariffCacheKey(tenantId); var tariff = _cache.Get(key); if (tariff == null) { tariff = GetBillingInfo(tenantId); tariff = CalculateTariff(tenantId, tariff); _cache.Insert(key, tariff, DateTime.UtcNow.Add(GetCacheExpiration())); if (_billingClient.Configured && withRequestToPaymentSystem) { //Task.Run(() => // { try { var currentPayments = _billingClient.GetCurrentPayments(GetPortalId(tenantId)); if (currentPayments.Length == 0) throw new BillingNotFoundException("Empty PaymentLast"); var asynctariff = Tariff.CreateDefault(true); string email = null; foreach (var currentPayment in currentPayments) { var quota = _quotaService.GetTenantQuotas().SingleOrDefault(q => q.ProductId == currentPayment.ProductId.ToString()); if (quota == null) { throw new InvalidOperationException($"Quota with id {currentPayment.ProductId} not found for portal {GetPortalId(tenantId)}."); } var paymentEndDate = 9999 <= currentPayment.EndDate.Year ? DateTime.MaxValue : currentPayment.EndDate; asynctariff.DueDate = DateTime.Compare(asynctariff.DueDate, paymentEndDate) < 0 ? asynctariff.DueDate : paymentEndDate; asynctariff.Quotas.Add(new Tuple(quota.Tenant, currentPayment.Quantity)); email = currentPayment.PaymentEmail; } if (!string.IsNullOrEmpty(email)) { var customer = _userService.GetUser(tenantId, email); asynctariff.CustomerId = customer != null && !customer.Removed ? customer.Id : Guid.Empty; } if (SaveBillingInfo(tenantId, asynctariff)) { asynctariff = CalculateTariff(tenantId, asynctariff); ClearCache(tenantId); _cache.Insert(key, asynctariff, DateTime.UtcNow.Add(GetCacheExpiration())); } } catch (BillingNotFoundException) { var freeTariff = tariff.Quotas.Exists(tariffRow => { var q = _quotaService.GetTenantQuota(tariffRow.Item1); return q == null || q.Trial || q.Free || q.NonProfit || q.Custom; }); if (!freeTariff) { var asynctariff = Tariff.CreateDefault(); asynctariff.DueDate = DateTime.Today.AddDays(-1); asynctariff.State = TariffState.NotPaid; if (SaveBillingInfo(tenantId, asynctariff)) { asynctariff = CalculateTariff(tenantId, asynctariff); ClearCache(tenantId); _cache.Insert(key, asynctariff, DateTime.UtcNow.Add(GetCacheExpiration())); } } } catch (Exception error) { LogError(error, tenantId.ToString()); } //}); } } return tariff; } public async Task PaymentChange(int tenantId, Dictionary quantity) { if (quantity == null || !quantity.Any() || !_billingClient.Configured) { return false; } var allQuotas = _quotaService.GetTenantQuotas().Where(q => !string.IsNullOrEmpty(q.ProductId)); var newQuotas = quantity.Keys.Select(name => allQuotas.FirstOrDefault(q => q.Name == name)); var tariff = GetTariff(tenantId); // update the quantity of present quotas TenantQuota updatedQuota = null; foreach (var tariffRow in tariff.Quotas) { var quotaId = tariffRow.Item1; var qty = tariffRow.Item2; var quota = _quotaService.GetTenantQuota(quotaId); var mustUpdateQuota = newQuotas.FirstOrDefault(q => q.Tenant == quota.Tenant); if (mustUpdateQuota != null) { qty = quantity[mustUpdateQuota.Name]; } quota *= qty; updatedQuota += quota; } // add new quotas var addedQuotas = newQuotas.Where(q => !tariff.Quotas.Any(t => t.Item1 == q.Tenant)); foreach (var addedQuota in addedQuotas) { var qty = quantity[addedQuota.Name]; var quota = addedQuota; quota *= qty; updatedQuota += quota; } await updatedQuota.Check(_serviceProvider); var productIds = newQuotas.Select(q => q.ProductId); try { var changed = _billingClient.ChangePayment(GetPortalId(tenantId), productIds.ToArray(), quantity.Values.ToArray()); if (!changed) { return false; } ClearCache(tenantId); } catch (Exception error) { _logger.ErrorWithException(error); } return true; } public void SetTariff(int tenantId, Tariff tariff) { ArgumentNullException.ThrowIfNull(tariff); List quotas = null; if (tariff.Quotas == null || (quotas = tariff.Quotas.Select(q => _quotaService.GetTenantQuota(q.Item1)).ToList()).Any(q => q == null)) { return; } SaveBillingInfo(tenantId, tariff); if (quotas.Any(q => q.Trial)) { // reset trial date var tenant = _tenantService.GetTenant(tenantId); if (tenant != null) { tenant.VersionChanged = DateTime.UtcNow; _tenantService.SaveTenant(_coreSettings, tenant); } } ClearCache(tenantId); } internal static string GetTariffCacheKey(int tenantId) { return string.Format("{0}:{1}", tenantId, "tariff"); } internal static string GetBillingUrlCacheKey(int tenantId) { return string.Format("{0}:{1}", tenantId, "billing:urls"); } internal static string GetBillingPaymentCacheKey(int tenantId) { return string.Format("{0}:{1}", tenantId, "billing:payments"); } public void ClearCache(int tenantId) { _notify.Publish(new TariffCacheItem { TenantId = tenantId }, CacheNotifyAction.Remove); } public IEnumerable GetPayments(int tenantId) { var key = GetBillingPaymentCacheKey(tenantId); var payments = _cache.Get>(key); if (payments == null) { payments = new List(); if (_billingClient.Configured) { try { var quotas = _quotaService.GetTenantQuotas(); foreach (var pi in _billingClient.GetPayments(GetPortalId(tenantId))) { var quota = quotas.SingleOrDefault(q => q.ProductId == pi.ProductRef.ToString()); if (quota != null) { pi.QuotaId = quota.Tenant; } payments.Add(pi); } } catch (Exception error) { LogError(error, tenantId.ToString()); } } _cache.Insert(key, payments, DateTime.UtcNow.Add(TimeSpan.FromMinutes(10))); } return payments; } public async Task GetShoppingUri(int tenant, string currency = null, string language = null, string customerEmail = null, Dictionary quantity = null, string backUrl = null) { var hasQuantity = quantity != null && quantity.Any(); var key = "shopingurl_" + (hasQuantity ? string.Join('_', quantity.Keys.ToArray()) : "all"); var url = _cache.Get(key); if (url == null) { url = string.Empty; if (_billingClient.Configured) { var allQuotas = _quotaService.GetTenantQuotas().Where(q => !string.IsNullOrEmpty(q.ProductId) && q.Visible); var newQuotas = quantity.Select(item => allQuotas.FirstOrDefault(q => q.Name == item.Key)); TenantQuota updatedQuota = null; foreach (var addedQuota in newQuotas) { var qty = quantity[addedQuota.Name]; var quota = addedQuota; quota *= qty; updatedQuota += quota; } await updatedQuota.Check(_serviceProvider); var productIds = newQuotas.Select(q => q.ProductId); try { url = _billingClient.GetPaymentUrl( "__Tenant__", productIds.ToArray(), null, null, !string.IsNullOrEmpty(currency) ? "__Currency__" : null, !string.IsNullOrEmpty(language) ? "__Language__" : null, !string.IsNullOrEmpty(customerEmail) ? "__CustomerEmail__" : null, hasQuantity ? "__Quantity__" : null, !string.IsNullOrEmpty(backUrl) ? "__BackUrl__" : null ); } catch (Exception error) { _logger.ErrorWithException(error); } } _cache.Insert(key, url, DateTime.UtcNow.Add(TimeSpan.FromMinutes(10))); } ResetCacheExpiration(); if (string.IsNullOrEmpty(url)) { return null; } var result = new Uri(url.ToString() .Replace("__Tenant__", HttpUtility.UrlEncode(GetPortalId(tenant))) .Replace("__Currency__", HttpUtility.UrlEncode(currency ?? "")) .Replace("__Language__", HttpUtility.UrlEncode((language ?? "").ToLower())) .Replace("__CustomerEmail__", HttpUtility.UrlEncode(customerEmail ?? "")) .Replace("__Quantity__", hasQuantity ? string.Join(',', quantity.Values) : "") .Replace("__BackUrl__", HttpUtility.UrlEncode(backUrl ?? ""))); return result; } public Uri GetShoppingUri(int? tenant, int quotaId, string affiliateId, string currency = null, string language = null, string customerId = null, string quantity = null) { var quota = _quotaService.GetTenantQuota(quotaId); if (quota == null) { return null; } var key = tenant.HasValue ? GetBillingUrlCacheKey(tenant.Value) : string.Format($"notenant{(!string.IsNullOrEmpty(affiliateId) ? "_" + affiliateId : "")}"); key += quota.Visible ? "" : "0"; if (_cache.Get>(key) is not IDictionary urls) { urls = new Dictionary(); if (_billingClient.Configured) { try { var products = _quotaService.GetTenantQuotas() .Where(q => !string.IsNullOrEmpty(q.ProductId) && q.Visible == quota.Visible) .Select(q => q.ProductId) .ToArray(); urls = _billingClient.GetPaymentUrls( tenant.HasValue ? GetPortalId(tenant.Value) : null, products, tenant.HasValue ? GetAffiliateId(tenant.Value) : affiliateId, tenant.HasValue ? GetCampaign(tenant.Value) : null, !string.IsNullOrEmpty(currency) ? "__Currency__" : null, !string.IsNullOrEmpty(language) ? "__Language__" : null, !string.IsNullOrEmpty(customerId) ? "__CustomerID__" : null, !string.IsNullOrEmpty(quantity) ? "__Quantity__" : null ); } catch (Exception error) { _logger.ErrorGetShoppingUri(error); } } _cache.Insert(key, urls, DateTime.UtcNow.Add(TimeSpan.FromMinutes(10))); } ResetCacheExpiration(); if (!string.IsNullOrEmpty(quota.ProductId) && urls.TryGetValue(quota.ProductId, out var url)) { if (url == null) { return null; } url = new Uri(url.ToString() .Replace("__Currency__", HttpUtility.UrlEncode(currency ?? "")) .Replace("__Language__", HttpUtility.UrlEncode((language ?? "").ToLower())) .Replace("__CustomerID__", HttpUtility.UrlEncode(customerId ?? "")) .Replace("__Quantity__", HttpUtility.UrlEncode(quantity ?? ""))); return url; } return null; } public Uri GetShoppingUri(string[] productIds, string affiliateId = null, string currency = null, string language = null, string customerId = null, string quantity = null) { var key = "shopingurl" + string.Join("_", productIds) + (!string.IsNullOrEmpty(affiliateId) ? "_" + affiliateId : ""); var url = _cache.Get(key); if (url == null) { url = string.Empty; if (_billingClient.Configured) { try { url = _billingClient.GetPaymentUrl( null, productIds, affiliateId, null, !string.IsNullOrEmpty(currency) ? "__Currency__" : null, !string.IsNullOrEmpty(language) ? "__Language__" : null, !string.IsNullOrEmpty(customerId) ? "__CustomerID__" : null, !string.IsNullOrEmpty(quantity) ? "__Quantity__" : null ); } catch (Exception error) { _logger.ErrorWithException(error); } } _cache.Insert(key, url, DateTime.UtcNow.Add(TimeSpan.FromMinutes(10))); } ResetCacheExpiration(); if (string.IsNullOrEmpty(url)) { return null; } var result = new Uri(url.ToString() .Replace("__Currency__", HttpUtility.UrlEncode(currency ?? "")) .Replace("__Language__", HttpUtility.UrlEncode((language ?? "").ToLower())) .Replace("__CustomerID__", HttpUtility.UrlEncode(customerId ?? "")) .Replace("__Quantity__", HttpUtility.UrlEncode(quantity ?? ""))); return result; } public IDictionary> GetProductPriceInfo(params string[] productIds) { ArgumentNullException.ThrowIfNull(productIds); try { var key = "biling-prices" + string.Join(",", productIds); var result = _cache.Get>>(key); if (result == null) { result = _billingClient.GetProductPriceInfo(productIds); _cache.Insert(key, result, DateTime.Now.AddHours(1)); } return result; } catch (Exception error) { LogError(error); return productIds .Select(p => new { ProductId = p, Prices = new Dictionary() }) .ToDictionary(e => e.ProductId, e => e.Prices); } } public Uri GetAccountLink(int tenant, string backUrl) { var key = "accountlink_" + tenant; var url = _cache.Get(key); if (url == null) { if (_billingClient.Configured) { try { url = _billingClient.GetAccountLink(GetPortalId(tenant), backUrl); } catch (Exception error) { LogError(error); } } _cache.Insert(key, url, DateTime.UtcNow.Add(TimeSpan.FromMinutes(10))); } if (!string.IsNullOrEmpty(url)) { return new Uri(url); } return null; } private Tariff GetBillingInfo(int tenant) { using var coreDbContext = _dbContextFactory.CreateDbContext(); var r = coreDbContext.Tariffs .Where(r => r.Tenant == tenant) .OrderByDescending(r => r.Id) .FirstOrDefault(); if (r == null) { return Tariff.CreateDefault(); } var tariff = Tariff.CreateDefault(true); tariff.DueDate = r.Stamp.Year < 9999 ? r.Stamp : DateTime.MaxValue; tariff.CustomerId = r.CustomerId; var tariffRows = coreDbContext.TariffRows .Where(row => row.TariffId == r.Id && row.Tenant == tenant); tariff.Quotas = tariffRows.Select(r => new Tuple(r.Quota, r.Quantity)).ToList(); return tariff; } private bool SaveBillingInfo(int tenant, Tariff tariffInfo) { var inserted = false; var currentTariff = GetBillingInfo(tenant); if (!tariffInfo.EqualsByParams(currentTariff)) { using var dbContext = _dbContextFactory.CreateDbContext(); var strategy = dbContext.Database.CreateExecutionStrategy(); strategy.Execute(() => { using var dbContext = _dbContextFactory.CreateDbContext(); using var tx = dbContext.Database.BeginTransaction(); var efTariff = new DbTariff { Tenant = tenant, Stamp = tariffInfo.DueDate, CustomerId = tariffInfo.CustomerId, CreateOn = DateTime.UtcNow }; efTariff = dbContext.Tariffs.Add(efTariff).Entity; dbContext.SaveChanges(); var tariffRows = tariffInfo.Quotas.Select(q => new DbTariffRow { TariffId = efTariff.Id, Quota = q.Item1, Quantity = q.Item2, Tenant = tenant }); dbContext.TariffRows.AddRange(tariffRows); dbContext.SaveChanges(); _cache.Remove(GetTariffCacheKey(tenant)); inserted = true; tx.Commit(); }); } if (inserted) { var t = _tenantService.GetTenant(tenant); if (t != null) { // update tenant.LastModified to flush cache in documents _tenantService.SaveTenant(_coreSettings, t); } } return inserted; } public void DeleteDefaultBillingInfo() { const int tenant = Tenant.DefaultTenant; using var coreDbContext = _dbContextFactory.CreateDbContext(); var tariffs = coreDbContext.Tariffs.Where(r => r.Tenant == tenant).ToList(); foreach (var t in tariffs) { t.Tenant = -2; t.CreateOn = DateTime.UtcNow; } coreDbContext.SaveChanges(); ClearCache(tenant); } private Tariff CalculateTariff(int tenantId, Tariff tariff) { tariff.State = TariffState.Paid; if (tariff.Quotas.Count == 0) { tariff.Quotas.Add(new Tuple(Tenant.DefaultTenant, 1)); } var trial = tariff.Quotas.Exists(q => _quotaService.GetTenantQuota(q.Item1).Trial); var delay = 0; if (trial) { tariff.State = TariffState.Trial; if (tariff.DueDate == DateTime.MinValue || tariff.DueDate == DateTime.MaxValue) { var tenant = _tenantService.GetTenant(tenantId); if (tenant != null) { var fromDate = tenant.CreationDateTime < tenant.VersionChanged ? tenant.VersionChanged : tenant.CreationDateTime; var trialPeriod = GetPeriod("TrialPeriod", DefaultTrialPeriod); if (fromDate == DateTime.MinValue) { fromDate = DateTime.UtcNow.Date; } tariff.DueDate = trialPeriod != default ? fromDate.Date.AddDays(trialPeriod) : DateTime.MaxValue; } else { tariff.DueDate = DateTime.MaxValue; } } } else { delay = _paymentDelay; } if (tariff.DueDate != DateTime.MinValue && tariff.DueDate.Date < DateTime.Today && delay > 0) { tariff.State = TariffState.Delay; tariff.DelayDueDate = tariff.DueDate.Date.AddDays(delay); } if (tariff.DueDate == DateTime.MinValue || tariff.DueDate != DateTime.MaxValue && tariff.DueDate.Date.AddDays(delay) < DateTime.Today) { tariff.State = TariffState.NotPaid; } return tariff; } private int GetPeriod(string key, int defaultValue) { var settings = _tenantService.GetTenantSettings(Tenant.DefaultTenant, key); return settings != null ? Convert.ToInt32(Encoding.UTF8.GetString(settings)) : defaultValue; } private string GetPortalId(int tenant) { return _coreSettings.GetKey(tenant); } private string GetAffiliateId(int tenant) { return _coreSettings.GetAffiliateId(tenant); } private string GetCampaign(int tenant) { return _coreSettings.GetCampaign(tenant); } private TimeSpan GetCacheExpiration() { if (_coreBaseSettings.Standalone && _cacheExpiration < _standaloneCacheExpiration) { _cacheExpiration = _cacheExpiration.Add(TimeSpan.FromSeconds(30)); } return _cacheExpiration; } private void ResetCacheExpiration() { if (_coreBaseSettings.Standalone) { _cacheExpiration = _defaultCacheExpiration; } } private void LogError(Exception error, string tenantId = null) { if (error is BillingNotFoundException) { _logger.DebugPaymentTenant(tenantId, error.Message); } else if (error is BillingNotConfiguredException) { _logger.DebugBillingTenant(tenantId, error.Message); } else { if (_logger.IsEnabled(LogLevel.Debug)) { _logger.ErrorBillingWithException(tenantId, error); } else { _logger.ErrorBilling(tenantId, error.Message); } } } }