institutioncontract task

2025-11-12 15:37:24 +03:30
parent 2164aeb5bc
commit 193e9f587f
15 changed files with 847 additions and 1 deletions
--- a/BackgroundInstitutionContract/BackgroundInstitutionContract.Task/BackgroundInstitutionContract.Task.csproj
+++ b/BackgroundInstitutionContract/BackgroundInstitutionContract.Task/BackgroundInstitutionContract.Task.csproj
@@ -0,0 +1,19 @@
+<Project Sdk="Microsoft.NET.Sdk.Web">
+
+ <PropertyGroup>
+    <TargetFramework>net8.0</TargetFramework>
+    <Nullable>enable</Nullable>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <AssemblyName>BackgroundInstitutionContract.Task</AssemblyName>
+    <RootNamespace>BackgroundInstitutionContract.Task</RootNamespace>
+  </PropertyGroup>
+
+    <ItemGroup>
+      <ProjectReference Include="..\..\0_Framework\0_Framework.csproj" />
+      <ProjectReference Include="..\..\AccountManagement.Configuration\AccountManagement.Configuration.csproj" />
+      <ProjectReference Include="..\..\PersonalContractingParty.Config\PersonalContractingParty.Config.csproj" />
+      <ProjectReference Include="..\..\Query.Bootstrapper\Query.Bootstrapper.csproj" />
+      <ProjectReference Include="..\..\WorkFlow\Infrastructure\WorkFlow.Infrastructure.Config\WorkFlow.Infrastructure.Config.csproj" />
+    </ItemGroup>
+
+</Project>
--- a/BackgroundInstitutionContract/BackgroundInstitutionContract.Task/FileUploader.cs
+++ b/BackgroundInstitutionContract/BackgroundInstitutionContract.Task/FileUploader.cs
@@ -0,0 +1,32 @@
+using _0_Framework.Application;
+
+namespace BackgroundInstitutionContract.Task
+{
+    public class FileUploader : IFileUploader
+    {
+        private readonly IWebHostEnvironment _webHostEnvironment;
+
+        public FileUploader(IWebHostEnvironment webHostEnvironment)
+        {
+            _webHostEnvironment = webHostEnvironment;
+        }
+    
+        public string Upload(IFormFile file, string path)
+        {
+            if (file == null) return "";
+
+            var directoryPath = $"{_webHostEnvironment.WebRootPath}\\ProductPictures\\{path}";
+
+            if (!Directory.Exists(directoryPath))
+                Directory.CreateDirectory(directoryPath);
+
+            var fileName = $"{DateTime.Now.ToFileName()}-{file.FileName}";
+            var filePath = $"{directoryPath}\\{fileName}";
+            var output = System.IO.File.Create(filePath);
+            file.CopyTo(output);
+            return $"{path}/{fileName}";
+        }
+
+      
+    }
+}
--- a/BackgroundInstitutionContract/BackgroundInstitutionContract.Task/Jobs/JobSchedulerRegistrator.cs
+++ b/BackgroundInstitutionContract/BackgroundInstitutionContract.Task/Jobs/JobSchedulerRegistrator.cs
@@ -0,0 +1,80 @@
+
+using Hangfire;
+
+namespace BackgroundInstitutionContract.Task.Jobs;
+
+public class JobSchedulerRegistrator
+{
+    private readonly IBackgroundJobClient _backgroundJobClient;
+    private readonly SmsReminder _smsReminder;
+    private static DateTime? _lastRunDateMorning;
+    private static DateTime? _lastRunDateEvening;
+
+    public JobSchedulerRegistrator(SmsReminder smsReminder, IBackgroundJobClient backgroundJobClient)
+    {
+        _smsReminder = smsReminder;
+        _backgroundJobClient = backgroundJobClient;
+    }
+
+    public void Register()
+    {
+        RecurringJob.AddOrUpdate(
+            "Task.Test",
+            () => SmsReminderCheckAndSchedule(),
+            "*/1 * * * *"  // هر 5 دقیقه یکبار چک کن
+        );
+
+        RecurringJob.AddOrUpdate(
+            "Task.ReminderDebtSMS",
+            () => DebtSmsReminder(),
+            "*/1 * * * *"  // هر 1 دقیقه یکبار چک کن
+        );
+    }
+
+    /// <summary>
+    /// پیامک های یاد آور
+    /// </summary>
+    /// <returns></returns>
+    public void DebtSmsReminder()
+    {
+        var now = DateTime.Now;
+        _backgroundJobClient.Enqueue(() => _smsReminder.Execute());
+        _lastRunDateMorning = now;
+    }
+
+    public void SmsReminderCheckAndSchedule()
+    {
+        var now = DateTime.Now;
+
+        var startMorning = new TimeSpan(9, 0, 0);
+        var endMorning   = new TimeSpan(9, 40, 0);
+
+        var startEvening = new TimeSpan(15, 30, 0);
+        var endEvening   = new TimeSpan(15, 40, 0);
+
+        // صبح
+        if (now.DayOfWeek != DayOfWeek.Friday &&
+            now.TimeOfDay >= startMorning &&
+            now.TimeOfDay < endMorning)
+        {
+            if (_lastRunDateMorning?.Date != now.Date)
+            {
+                _backgroundJobClient.Enqueue(() => _smsReminder.Execute());
+                _lastRunDateMorning = now;
+            }
+        }
+
+        // عصر - پنجشنبه و جمعه تعطیل است
+        if (now.DayOfWeek != DayOfWeek.Friday &&
+            now.DayOfWeek != DayOfWeek.Thursday &&
+            now.TimeOfDay >= startEvening &&
+            now.TimeOfDay < endEvening)
+        {
+            if (_lastRunDateEvening?.Date != now.Date)
+            {
+                _backgroundJobClient.Enqueue(() => _smsReminder.Execute());
+                _lastRunDateEvening = now;
+            }
+        }
+    }
+}
--- a/BackgroundInstitutionContract/BackgroundInstitutionContract.Task/Jobs/SmsReminder.cs
+++ b/BackgroundInstitutionContract/BackgroundInstitutionContract.Task/Jobs/SmsReminder.cs
@@ -0,0 +1,116 @@
+using _0_Framework.Application.Sms;
+using AccountManagement.Application.Contracts.Account;
+using AccountMangement.Infrastructure.EFCore;
+using Company.Domain.SmsResultAgg;
+using Microsoft.EntityFrameworkCore;
+using SmsResult = Company.Domain.SmsResultAgg.SmsResult;
+
+namespace BackgroundInstitutionContract.Task.Jobs;
+public class SmsReminder
+{
+    private readonly AccountContext _accountContext;
+    private readonly ISmsService _smsService;
+    private readonly ISmsResultRepository _smsResultRepository;
+
+    public SmsReminder(ISmsService smsService, AccountContext accountContext, ISmsResultRepository smsResultRepository)
+    {
+        _smsService = smsService;
+        _accountContext = accountContext;
+        _smsResultRepository = smsResultRepository;
+    }
+
+    public void Execute()
+    {
+        //var accounts = _accountContext.Accounts.Where(x => x.PositionId > 0 && x.IsActiveString == "true").Select(x => new AccountViewModel() { Id = x.id, Mobile = x.Mobile, Fullname = x.Fullname }).ToList();
+        //Thread.Sleep(300);
+         //var accounts = new List<AccountViewModel>() { new AccountViewModel() { Mobile = "09114221321", Id = 2 } };
+        var accounts= _accountContext.Accounts.Where(x => x.Username.ToLower()=="mahan").Select(x => new AccountViewModel() { Id = x.id, Mobile = x.Mobile, Fullname = x.Fullname }).ToList();
+        var smsVM = accounts.Select(x => new AccountSmsTaskViewModel()
+        {
+            Mobile = x.Mobile,
+            AccountId = x.Id,
+            FullName = x.Fullname,
+            TaskCount = GetLateTasksCount(x.Id)
+        }).Where(x => x.TaskCount > 0 && !string.IsNullOrEmpty(x.Mobile) && x.Mobile.Length == 11).ToList();
+        Thread.Sleep(300);
+
+
+        foreach (var viewmodel in smsVM)
+        {
+            var smsResult = _smsService.TaskReminderSms(viewmodel.Mobile, $"{viewmodel.TaskCount}");
+            Thread.Sleep(1000);
+            var createSmsResult = new SmsResult(smsResult.MessageId, smsResult.Message, "یادآور وظایف",
+                viewmodel.FullName, viewmodel.Mobile, viewmodel.AccountId, viewmodel.AccountId);
+            _smsResultRepository.Create(createSmsResult);
+            _smsResultRepository.SaveChanges();
+            Thread.Sleep(1000);
+        }
+    }
+     private int GetLateTasksCount(long accountId)
+    {
+        var positionValue = _accountContext.Accounts
+            .Where(x => x.id == accountId)
+            .Include(p => p.Position)
+            .Select(x => x.Position.PositionValue)
+            .FirstOrDefault();
+
+        if (positionValue == 0)
+            return 0;
+
+
+        DateTime now = DateTime.Now;
+        int overdueTasksCount;
+
+        if (positionValue == 1)
+        {
+            overdueTasksCount = _accountContext.Assigns.Include(x => x.Task).Where(x => x.AssignedId == accountId &&
+                    x.AssignerId == accountId && x.Task.Assigns.Count == 1 &&
+                    !x.IsCancel && !x.IsCanceledRequest &&
+                    !x.IsDone && !x.TimeRequest && !x.IsDoneRequest && x.EndTaskDate.Date <= DateTime.Now.Date && x.Task.IsActiveString == "true")
+                .GroupBy(x => x.TaskId).Select(x => x.First()).Count();
+
+            //overdueTasksCount = _accountContext.Tasks.Include(x =>
+            //	x.Assigns).Count(x => !x.Assigns.Any(a => a.IsCancel) && !x.Assigns.Any(a => a.IsCanceledRequest) &&
+            //						  !x.Assigns.Any(a => a.IsDone) && !x.Assigns.Any(a => a.IsDoneRequest) &&
+            //						  !x.Assigns.Any(a => a.TimeRequest)
+            //						  && x.Assigns.Any(a => a.AssignedId == accountId && a.AssignerId == accountId) &&
+            //						  (x.Assigns.First(a => a.AssignedId == accountId && a.AssignerId == accountId)
+            //							  .EndTaskDate.Date <= DateTime.Now.Date) && x.Assigns.Count == 1);
+        }
+        else
+        {
+
+            overdueTasksCount = _accountContext.Assigns
+                .Include(x => x.Task)
+                .Where(x => x.AssignedId == accountId &&
+                            !x.IsCancel && !x.IsCanceledRequest &&
+                            !x.IsDone && !x.TimeRequest && !x.IsDoneRequest && x.EndTaskDate.Date <= DateTime.Now.Date && x.Task.IsActiveString == "true")
+                .GroupBy(x => x.TaskId).Select(x => x.First()).Count();
+        }
+
+
+        //overdueTasksCount = _accountContext.Tasks.Include(x =>
+        //	x.Assigns).Count(x => !x.Assigns.Any(a => a.IsCancel) && !x.Assigns.Any(a => a.IsCanceledRequest) &&
+        //	                      !x.Assigns.Any(a => a.IsDone) && !x.Assigns.Any(a => a.IsDoneRequest) &&
+        //	                      !x.Assigns.Any(a => a.TimeRequest)
+        //	                      && x.Assigns.Any(a => a.AssignedId == accountId) &&
+        //	                      (x.Assigns.First(a => a.AssignedId == accountId).EndTaskDate.Date <= DateTime.Now.Date));
+
+
+        var overdueRequestsCount = _accountContext.Assigns.Include(x => x.Task)
+            .Where(x => (x.IsCanceledRequest
+                         || x.IsDoneRequest || x.TimeRequest) && !x.IsCancel && !x.IsDone &&
+                        x.Task.IsActiveString == "true" &&
+                        x.Task.SenderId == accountId).GroupBy(x => x.TaskId).Select(x => x.First()).Count();
+
+        return overdueTasksCount + overdueRequestsCount;
+    }
+    
+}
+public class AccountSmsTaskViewModel
+{
+    public int TaskCount { get; set; }
+    public long AccountId { get; set; }
+    public string Mobile { get; set; }
+    public string FullName { get; set; }
+}
--- a/BackgroundInstitutionContract/BackgroundInstitutionContract.Task/JobsBootstrapper.cs
+++ b/BackgroundInstitutionContract/BackgroundInstitutionContract.Task/JobsBootstrapper.cs
@@ -0,0 +1,25 @@
+using BackgroundInstitutionContract.Task.Jobs;
+
+
+namespace BackgroundInstitutionContract.Task;
+
+public class JobsBootstrapper
+{
+    public static void Configure(IServiceCollection services)
+    {
+        var currentNamespace = typeof(JobSchedulerRegistrator).Namespace; // همون namespace کلاس
+
+        var assembly = typeof(JobSchedulerRegistrator).Assembly;
+
+        var jobTypes = assembly.GetTypes()
+            .Where(t =>
+                t is { IsClass: true, IsAbstract: false, Namespace: not null } &&
+                t.Namespace.StartsWith(currentNamespace, StringComparison.Ordinal))
+            .ToList();
+
+        foreach (var jobType in jobTypes)
+        {
+            services.AddTransient(jobType);
+        }
+    }
+}
--- a/BackgroundInstitutionContract/BackgroundInstitutionContract.Task/Program.cs
+++ b/BackgroundInstitutionContract/BackgroundInstitutionContract.Task/Program.cs
@@ -0,0 +1,59 @@
+using _0_Framework.Application;
+using _0_Framework.Application.Sms;
+using _0_Framework.Application.UID;
+using _0_Framework.InfraStructure.Mongo;
+using AccountManagement.Configuration;
+using BackgroundInstitutionContract.Task;
+using BackgroundInstitutionContract.Task.Jobs;
+using CompanyManagment.EFCore.Services;
+using Hangfire;
+using Microsoft.AspNetCore.Identity;
+using MongoDB.Driver;
+using PersonalContractingParty.Config;
+using Query.Bootstrapper;
+using WorkFlow.Infrastructure.Config;
+
+var builder = WebApplication.CreateBuilder(args);
+var hangfireConnectionString = builder.Configuration.GetConnectionString("HangfireDb");
+builder.Services.AddHangfire(x => x.UseSqlServerStorage(hangfireConnectionString));
+builder.Services.AddHangfireServer();
+var connectionString = builder.Configuration.GetConnectionString("MesbahDb");
+var connectionStringTestDb = builder.Configuration.GetConnectionString("TestDb");
+builder.Services.AddSingleton<IPasswordHasher, PasswordHasher>();
+builder.Services.AddTransient<IAuthHelper, AuthHelper>();
+builder.Services.AddTransient<ISmsService, SmsService>();
+builder.Services.AddTransient<IUidService, UidService>();
+builder.Services.AddTransient<IFileUploader, FileUploader>();
+builder.Services.Configure<AppSettingConfiguration>(builder.Configuration);
+
+#region MongoDb
+
+var mongoConnectionSection = builder.Configuration.GetSection("MongoDb");
+var mongoDbSettings = mongoConnectionSection.Get<MongoDbConfig>();
+var mongoClient = new MongoClient(mongoDbSettings.ConnectionString);
+var mongoDatabase = mongoClient.GetDatabase(mongoDbSettings.DatabaseName);
+
+builder.Services.AddSingleton<IMongoDatabase>(mongoDatabase);
+
+#endregion
+
+PersonalBootstrapper.Configure(builder.Services, connectionString);
+TestDbBootStrapper.Configure(builder.Services, connectionStringTestDb);
+AccountManagementBootstrapper.Configure(builder.Services, connectionString);
+WorkFlowBootstrapper.Configure(builder.Services, connectionString);
+QueryBootstrapper.Configure(builder.Services);
+JobsBootstrapper.Configure(builder.Services);
+builder.Services.AddHttpClient();
+builder.Services.AddHttpContextAccessor();
+var app = builder.Build();
+
+app.MapHangfireDashboard();
+app.MapGet("/", () => "Hello World!");
+
+using (var scope = app.Services.CreateScope())
+{
+    var jobScheduler = scope.ServiceProvider.GetRequiredService<JobSchedulerRegistrator>();
+    jobScheduler.Register();
+}
+
+app.Run();
--- a/BackgroundInstitutionContract/BackgroundInstitutionContract.Task/Properties/launchSettings.json
+++ b/BackgroundInstitutionContract/BackgroundInstitutionContract.Task/Properties/launchSettings.json
@@ -0,0 +1,38 @@
+{
+  "$schema": "http://json.schemastore.org/launchsettings.json",
+  "iisSettings": {
+    "windowsAuthentication": false,
+    "anonymousAuthentication": true,
+    "iisExpress": {
+      "applicationUrl": "http://localhost:56492",
+      "sslPort": 44378
+    }
+  },
+  "profiles": {
+    "http": {
+      "commandName": "Project",
+      "dotnetRunMessages": true,
+      "launchBrowser": true,
+      "applicationUrl": "http://localhost:5216",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    },
+    "https": {
+      "commandName": "Project",
+      "dotnetRunMessages": true,
+      "launchBrowser": true,
+      "applicationUrl": "https://localhost:7223;http://localhost:5217",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    },
+    "IIS Express": {
+      "commandName": "IISExpress",
+      "launchBrowser": true,
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    }
+  }
+}
--- a/BackgroundInstitutionContract/BackgroundInstitutionContract.Task/appsettings.Development.json
+++ b/BackgroundInstitutionContract/BackgroundInstitutionContract.Task/appsettings.Development.json
@@ -0,0 +1,46 @@
+{
+  "DetailedErrors": true,
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft": "Warning",
+      "Microsoft.Hosting.Lifetime": "Information"
+    }
+  },
+  "ConnectionStrings": {
+    //تست
+    //"MesbahDb": "Data Source=DESKTOP-NUE119G\\MSNEW;Initial Catalog=Mesbah_db;Integrated Security=True"
+
+    //server
+    //"MesbahDb": "Data Source=171.22.24.15;Initial Catalog=mesbah_db;Persist Security Info=False;User ID=ir_db;Password=R2rNp[170]18[3019]#@ATt;TrustServerCertificate=true;",
+
+
+    //local
+    "MesbahDb": "Data Source=.;Initial Catalog=mesbah_db;Integrated Security=True;TrustServerCertificate=true;",
+
+    //dad-mehr
+    //"MesbahDb": "Data Source=.;Initial Catalog=teamWork;Integrated Security=True;TrustServerCertificate=true;",
+
+    "TestDb": "Data Source=.;Initial Catalog=TestDb;Integrated Security=True;TrustServerCertificate=true;",
+
+    //mahan Docker
+    //"MesbahDb": "Data Source=localhost,5069;Initial Catalog=mesbah_db;User ID=sa;Password=YourPassword123;TrustServerCertificate=True;",
+    "HangfireDb": "Data Source=.;Initial Catalog=hangfire_db;Integrated Security=True;TrustServerCertificate=true;"
+  },
+
+  "GoogleRecaptchaV3": {
+    "SiteKey": "6Lfhp_AnAAAAAB79WkrMoHd1k8ir4m8VvfjE7FTH",
+    "SecretKey": "6Lfhp_AnAAAAANjDDY6DPrbbUQS7k6ZCRmrVP5Lb"
+  },
+  "SmsSecrets": {
+    "ApiKey": "Og5M562igmzJRhQPnq0GdtieYdLgtfikjzxOmeQBPxJjZtyge5Klc046Lfw1mxSa",
+    "SecretKey": "dadmehr"
+  },
+  "Domain": ".gozareshgir.ir",
+  "MongoDb": {
+    "ConnectionString": "mongodb://localhost:27017",
+    "DatabaseName": "Gozareshgir"
+  }
+
+
+}
--- a/BackgroundInstitutionContract/BackgroundInstitutionContract.Task/appsettings.json
+++ b/BackgroundInstitutionContract/BackgroundInstitutionContract.Task/appsettings.json
@@ -0,0 +1,9 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  },
+  "AllowedHosts": "*"
+}