Merge pull request #10 from NiceOneFox/develop

Sprint 1

Author: NiceOneFox

README.md

@@ -1,2 +1,15 @@
 # ServiceSimulationSystem
- 
+
+Project aim is build service simulation system that has flow of requests which are created by sources. Requests is taken by devices on work, if they are no free devices requests go in buffer, also if new requests haven't come we take requests from buffer.
+
+
+## Technologies
+- ASP .NET 6
+- C# 10
+
+## Architecture 
+N-Layer Web API
+
+## Used Design Patterns
+1. Factory Pattern (Concrete implementation chosen by input parameter and provided by IoC)
+2. Dependency Injection (DI)

backend/ServiceSimulation/Bll.Domain/Bll.Domain.csproj

@@ -0,0 +1,9 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>net6.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+  </PropertyGroup>
+
+</Project>

backend/ServiceSimulation/Bll.Domain/Entities/BufferManagerFactory.cs

@@ -0,0 +1,24 @@
+using Api.enums;
+using Bll.Domain.Factories;
+using Bll.Domain.Interfaces;
+
+namespace Bll.Domain.Entities;
+
+public class BufferManagerFactory : IBufferManagerFactory
+{
+    private readonly IServiceProvider serviceProvider;
+
+    public BufferManagerFactory(IServiceProvider serviceProvider)
+    {
+        this.serviceProvider = serviceProvider;
+    }
+
+    public IBufferManager CreateBufferManager(SimulationType simulationType)
+    {
+        return simulationType switch
+        {
+            0 => (IBufferManager)serviceProvider.GetService(typeof(StandardBufferManager)),
+            _ => throw new NotImplementedException()
+        };
+    }
+}

backend/ServiceSimulation/Bll.Domain/Entities/Device.cs

@@ -0,0 +1,10 @@
+namespace Bll.Domain.Entities;
+
+public class Device
+{
+    public int DeviceId { get; set; }
+    public bool IsWorking { get; set; }
+    public Request? Request { get; set; }
+    public double Lambda { get; set; } = 5;
+    public double TimeOfDeviceWillBeFree { get; set; } = 0;
+}

backend/ServiceSimulation/Bll.Domain/Entities/DeviceManager.cs

@@ -0,0 +1,45 @@
+using Bll.Domain.Interfaces;
+
+namespace Bll.Domain.Entities;
+
+public class DeviceManager : IDeviceManager
+{
+    private readonly ITimeProvider _time;
+
+    private readonly IResults _resultChannel;
+
+    private static readonly Random _random = new();
+
+    public DeviceManager(ITimeProvider time, IResults resultChannel)
+    {
+        _time = time;
+        _resultChannel = resultChannel;
+    }
+
+    public void TakeRequest(Request request, Device device)
+    {
+        if (device.IsWorking)
+        {
+            return;
+        }
+        device.Request = request;
+        device.IsWorking = true;
+
+        device.TimeOfDeviceWillBeFree = _time.Now + (-1.0 / device.Lambda) * Math.Log(_random.NextDouble());
+    }
+
+    public bool FreeDevice(Device device)
+    {
+        device.Request.EndTime = _time.Now;
+
+        _time.Now = device.Request.EndTime;
+
+        _resultChannel.Processed.Add(device.Request);
+
+
+        device.Request = null;
+        device.IsWorking = false;
+
+        return true;
+    }
+}

backend/ServiceSimulation/Bll.Domain/Entities/InputParameters.cs

@@ -0,0 +1,15 @@
+using Api.enums;
+
+namespace Bll.Domain.Entities;
+
+public class InputParameters
+{
+    public int NumberOfSources { get; set; } = 3;
+    public int NumberOfDevices { get; set; } = 2;
+    public int BufferSize { get; set; } = 2;
+    public int AmountOfRequests { get; set; } = 40;
+    public double ModelingTime { get; set; } = double.MaxValue;
+    public SimulationType SimulationType { get; set; } = SimulationType.Standard;
+
+    public double Lambda { get; set; } = 3;
+}

backend/ServiceSimulation/Bll.Domain/Entities/Request.cs

@@ -0,0 +1,20 @@
+namespace Bll.Domain.Entities;
+
+public class Request
+{
+    public int NumberOfSource { get; set; }
+    public int SerialNumberOfSource { get; set; }
+    public double StartTime { get; set; }
+    public double EndTime { get; set; }
+    
+    public Request(int numberOfSource, int serialNumberOfSource, double startTime, double endTime)
+    {
+        NumberOfSource = numberOfSource;
+        SerialNumberOfSource = serialNumberOfSource;
+        StartTime = startTime;
+        EndTime = endTime;
+    }
+
+    public override string ToString()
+        => "Time: " + StartTime + " №sourceManager: " + NumberOfSource + "-" + SerialNumberOfSource;
+}

backend/ServiceSimulation/Bll.Domain/Entities/Results.cs

@@ -0,0 +1,16 @@
+using Bll.Domain.Interfaces;
+
+namespace Bll.Domain.Entities;
+
+public class Results : IResults
+{
+    public List<Request> Cancelled { get; set; } = new();
+    public List<Request> Processed { get; set; } = new();
+    public double ModelingTime { get; set; }
+    public int AmountOfGeneratedRequests { get; set; }
+    public int AmountOfServedRequest
+    {
+        get => Cancelled.Count + Processed.Count;
+        set { }
+    }
+}

backend/ServiceSimulation/Bll.Domain/Entities/Source.cs

@@ -0,0 +1,10 @@
+namespace Bll.Domain.Entities;
+
+public class Source
+{
+    public int SourceId { get; set; }
+    public int Priority { get; set; }
+    public int SerialNumber { get; set; }
+    public double TimeOfNextRequest { get; set; }
+    public double Lambda { get; set; } = 5;
+}

backend/ServiceSimulation/Bll.Domain/Entities/SourceManager.cs

@@ -0,0 +1,32 @@
+using Bll.Domain.Interfaces;
+
+namespace Bll.Domain.Entities;
+
+public class SourceManager : ISourceManager
+{
+    private readonly ITimeProvider _time;
+
+    private readonly IResults _results;
+
+    private static Random _random = new();
+
+    public SourceManager(ITimeProvider time, IResults results)
+    {
+        _time = time;
+        _results = results;
+    }
+
+    public Request GetNewRequest(Source source)
+    {
+        var generatedRequest = new Request(source.SourceId, source.SerialNumber, source.TimeOfNextRequest, -1);
+        
+        source.TimeOfNextRequest += -(1.0 / source.Lambda) * Math.Log(_random.NextDouble());
+        source.SerialNumber++;
+        generatedRequest.SerialNumberOfSource = source.SerialNumber; // TODO REFACTOR? 
+
+        _time.Now = source.TimeOfNextRequest;
+        _results.AmountOfGeneratedRequests++;
+
+        return generatedRequest;
+    }
+}