Changeset e0cdea2 for FarmatikoServices/Services/Service.cs

Timestamp:

02/08/21 16:39:25 (4 years ago)

Author:

Dimitar Slezenkovski <dslezenkovski@…>

Branches:

master

Children:

8eb1e21, dae4cde

Parents:

0a694bb

Message:

Fix all bugs

File:

• FarmatikoServices/Services/Service.cs (modified) (7 diffs)

FarmatikoServices/Services/Service.cs

@@ -3 +3 @@
 using FarmatikoData.Models;
 using FarmatikoServices.FarmatikoServiceInterfaces;
+using Microsoft.Extensions.Logging;
+using Newtonsoft.Json.Linq;
+using RestSharp;
 using System;
 using System.Collections.Generic;
@@ -13 +16 @@
     {
         private readonly IRepository _repository;
-        public Service(IRepository repository)
+        private readonly IPHRepo _phrepo;
+        private readonly ILogger _logger;
+        public Service(IRepository repository, IPHRepo phrepo, ILogger logger)
         {
             _repository = repository;
+            _phrepo = phrepo;
+            _logger = logger;
         }
 
@@ -76 +83 @@
         }
 
-        public async Task<Pandemic> GetPandemic()
-        {
-            var Pandemic = await _repository.GetPandemic();
-            return Pandemic;
+        public Pandemic GetPandemic()
+        {
+            //var Pandemic = await _repository.GetPandemic();
+
+            try
+            {
+                var Date = DateTime.UtcNow.ToString("yyyy-MM-dd");
+                var client = new RestClient($"https://api.covid19tracking.narrativa.com/api/{Date}/country/north_macedonia");
+                var response = client.Execute(new RestRequest());
+                string original = response.Content;
+                var jsonResponsePandemic = JObject.Parse(original);
+                if (!jsonResponsePandemic.ContainsKey("total"))
+                {
+                    Date = DateTime.UtcNow.AddDays(-1).ToString("yyyy-MM-dd");
+                    client = new RestClient($"https://api.covid19tracking.narrativa.com/api/{Date}/country/north_macedonia");
+                    response = client.Execute(new RestRequest());
+                    original = response.Content;
+                    jsonResponsePandemic = JObject.Parse(original);
+                    if (!jsonResponsePandemic.ContainsKey("total"))
+                    {
+                        Date = DateTime.UtcNow.AddDays(-2).ToString("yyyy-MM-dd");
+                        client = new RestClient($"https://api.covid19tracking.narrativa.com/api/{Date}/country/north_macedonia");
+                        response = client.Execute(new RestRequest());
+                        original = response.Content;
+                        jsonResponsePandemic = JObject.Parse(original);
+                    }
+                }
+                var global = JObject.Parse(jsonResponsePandemic.GetValue("total").ToString());
+                var TotalConfirmed = long.Parse(global.GetValue("today_confirmed").ToString());
+                var TotalDeaths = long.Parse(global.GetValue("today_deaths").ToString());
+                var TotalRecovered = long.Parse(global.GetValue("today_new_recovered").ToString());
+
+                var mk = JObject.Parse(jsonResponsePandemic.GetValue("dates").ToString());
+
+                var date = JObject.Parse(mk.GetValue(Date).ToString());
+                var country = JObject.Parse(date.GetValue("countries").ToString());
+                var mkd = JObject.Parse(country.GetValue("North Macedonia").ToString());
+                dynamic objP = mkd;
+                var TotalMk = Int32.Parse(objP.GetValue("today_confirmed").ToString());
+                var TotalDeathsMK = Int32.Parse(objP.GetValue("today_deaths").ToString());
+                var TotalRecoveredMK = Int32.Parse(objP.GetValue("today_recovered").ToString());
+                var NewMK = Int32.Parse(objP.GetValue("today_new_confirmed").ToString());
+
+                var Name = "Coronavirus";
+                var ActiveMk = TotalMk - (TotalRecoveredMK + TotalDeathsMK);
+                var ActiveGlobal = TotalConfirmed - (TotalRecovered + TotalDeaths);
+
+                Pandemic pandemic = new Pandemic(Name, TotalMk, ActiveMk, TotalDeathsMK, NewMK, TotalConfirmed, TotalDeaths, ActiveGlobal);
+                return pandemic;
+            }
+            catch (Exception e)
+            {
+                _logger.LogInformation(e.Message);
+            }
+            return null;
         }
 
@@ -86 +144 @@
             var Pharmacies = await _repository.GetPharmacies();
             List<PharmacyDTO> pharmacies = new List<PharmacyDTO>();
-
+            
             foreach(var pharm in Pharmacies)
             {
@@ -124 +182 @@
         }
 
-        public async Task<IEnumerable<Medicine>> SearchMedicines(string query)
+        public async Task<IEnumerable<MedicineDTO>> SearchMedicines(string query)
         {
             var SearchQuery = await _repository.SearchMedicines(query);
-            return SearchQuery;
-        }
-
-        public async Task<IEnumerable<Pharmacy>> SearchPharmacies(string query)
+            List<MedicineDTO> list = new List<MedicineDTO>();
+            var listPHMedicines = await _repository.GetAllPHMedicines();
+            List<string> headNames = new List<string>();
+            List<PharmacyHead> heads = new List<PharmacyHead>();
+            foreach (var med in SearchQuery)
+            {
+                var meds = listPHMedicines.Where(x => x.MedicineId == med.Id).ToList();
+                if (meds != null)
+                {
+                    heads = meds.Select(x => x.Head).ToList();
+                }
+                if (heads != null)
+                    headNames = heads?.Select(x => x?.Name).ToList();
+                MedicineDTO medicine = new MedicineDTO()
+                {
+                    Name = med.Name,
+                    Manufacturer = med.Manufacturer,
+                    Packaging = med.Packaging,
+                    Form = med.Form,
+                    Price = med.Price,
+                    Strength = med.Strength,
+                    WayOfIssuing = med.WayOfIssuing,
+                    HeadNames = headNames
+                };
+
+                list.Add(medicine);
+                headNames = new List<string>();
+            }
+
+            return list;
+        }
+
+        public async Task<IEnumerable<PharmacyDTO>> SearchPharmacies(string query)
         {
             var SearchQuery = await _repository.SearchPharmacies(query);
-            return SearchQuery;
+            List<PharmacyDTO> pharmacies = new List<PharmacyDTO>();
+            var heads = await _phrepo.GetPharmacyHeadInfo();
+            
+            foreach (var pharm in SearchQuery)
+            {
+                PharmacyDTO pharmacyDTO = new PharmacyDTO()
+                {
+                    Name = pharm.Name,
+                    Location = pharm.Location,
+                    Address = pharm.Address,
+                    WorkAllTime = pharm.WorkAllTime
+                };
+                
+                foreach(var head in heads.ToList())
+                {
+                    if (head.Pharmacies.Contains(pharm))
+                    {
+                        pharmacyDTO.HeadName = head.Name;
+                        break;
+                    }
+                }
+                
+                pharmacies.Add(pharmacyDTO);
+            }
+            return pharmacies;
         }
 
@@ -166 +277 @@
         }
         // Samo PharmacyHead i Admin imaat pristap
-        public async Task AddPharmacy(Pharmacy pharmacy)
+        public void AddPharmacy(Pharmacy pharmacy)
         {
             if (pharmacy != null)
-                await _repository.AddPharmacy(pharmacy);
+                _repository.AddPharmacy(pharmacy);
             else throw new Exception("Pharmacy is null");
         }
 
         // Ovaa kontrola ja ima samo admin
-        public async Task<User> MakeUser(PharmacyHead head)
-        {
-            User user = new User()
-            {
-                Name = head.Name,
-                Password = head.Password,
-                Email = head.Email,
-                UserRole = User.Role.PharmacyHead
-            };
-            bool Success = await _repository.AddUser(user);
-            if (!Success)
-                return null;
-            return user;
-        }
+        
         public async Task<bool> AddPharmacyHead(PharmacyHeadDto pharmacyHead)
         {
@@ -198 +296 @@
                     Password = pharmacyHead.Password
                 };
-                var user = await MakeUser(phead);
+                User user = new User()
+                {
+                    Name = phead.Name,
+                    Password = phead.Password,
+                    Email = phead.Email,
+                    UserRole = User.Role.PharmacyHead
+                };
                 if (user is null)
                 {
                     return false;
                 }
-                var users = _repository.GetUsers();
-                var thisUser = users.Where(usr => usr.Value.Email.Equals(user.Email)).Select(x => x.Value).FirstOrDefault();
                 User user1 = new User()
                 {
-                    Name = thisUser.Name,
-                    Password = thisUser.Password,
-                    Email = thisUser.Email,
-                    UserRole = thisUser.UserRole
+                    Name = user.Name,
+                    Password = user.Password,
+                    Email = user.Email,
+                    UserRole = user.UserRole
                 };
                 phead.User = user1;