Changeset f554983 for FarmatikoServices/Services/Service.cs

Timestamp:

02/14/21 17:54:35 (3 years ago)

Author:

Dimitar Slezenkovski <dslezenkovski@…>

Branches:

master

Children:

472dd7e

Parents:

6e6f04b

Message:

Add cron job for updating data, with Quartz.NET

File:

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

FarmatikoServices/Services/Service.cs

@@ -144 +144 @@
             var Pharmacies = await _repository.GetPharmacies();
             List<PharmacyDTO> pharmacies = new List<PharmacyDTO>();
-            
-            foreach(var pharm in Pharmacies)
+
+            foreach (var pharm in Pharmacies)
             {
                 PharmacyDTO pharmacyDTO = new PharmacyDTO()
@@ -222 +222 @@
             List<PharmacyDTO> pharmacies = new List<PharmacyDTO>();
             var heads = await _phrepo.GetPharmacyHeadInfo();
-            
+
             foreach (var pharm in SearchQuery)
             {
@@ -232 +232 @@
                     WorkAllTime = pharm.WorkAllTime
                 };
-                
-                foreach(var head in heads.ToList())
+
+                foreach (var head in heads.ToList())
                 {
                     if (head.Pharmacies.Contains(pharm))
@@ -241 +241 @@
                     }
                 }
-                
+
                 pharmacies.Add(pharmacyDTO);
             }
@@ -256 +256 @@
         //POST (ADD NEW OBJECTS)
         //za json(Sys updateer)
-        public async Task AddFacility(HealthFacility healthFacilities)
-        {
-            if (healthFacilities != null)
-                await _repository.AddFacility(healthFacilities);
+        public async Task AddFacility(HealthFacility healthFacility)
+        {
+            if (healthFacility != null)
+            {
+                var facilities = await _repository.GetFacilities();
+                if (!facilities.Contains(healthFacility))
+                {
+                    await _repository.AddFacility(healthFacility);
+                }
+                else throw new Exception("The facility already exists.");
+            }
             else throw new Exception("Facility is null");
         }
@@ -266 +273 @@
         {
             if (medicine != null)
-                await _repository.AddMedicines(medicine);
+            {
+                var medicines = await _repository.GetMedicinesAsync();
+                if (!medicines.Contains(medicine))
+                    await _repository.AddMedicines(medicine);
+                else throw new Exception("Medicine already exists.");
+            }
             else throw new Exception("Medicine is null");
         }
@@ -277 +289 @@
         }
         // Samo PharmacyHead i Admin imaat pristap
-        public void AddPharmacy(Pharmacy pharmacy)
+        public async void AddPharmacy(Pharmacy pharmacy)
         {
             if (pharmacy != null)
-                _repository.AddPharmacy(pharmacy);
+            {
+                var pharmacies = await _repository.GetPharmacies();
+                if (!pharmacies.Contains(pharmacy))
+                    await _repository.AddPharmacy(pharmacy);
+                else throw new Exception("Pharmacy already exists.");
+            }
             else throw new Exception("Pharmacy is null");
         }
 
         // Ovaa kontrola ja ima samo admin
-        
+
         public async Task<bool> AddPharmacyHead(PharmacyHeadDto pharmacyHead)
         {
@@ -324 +341 @@
         {
             if (worker != null)
-                await _repository.AddWorker(worker);
+            {
+                var workers = await _repository.GetAllWorkers();
+                if (!workers.Contains(worker))
+                    await _repository.AddWorker(worker);
+                else throw new Exception("Worker already exists.");
+            }
             else throw new Exception("Worker is null");
         }