Ignore:
File:
1 edited

Legend:

Unmodified
Added
Removed

  • FarmatikoServices/Services/ProcessJSONService.cs

    rc406ae5 rc73269d  
    1010using FarmatikoServices.FarmatikoServiceInterfaces;
    1111using RestSharp;
    12 using System.Threading.Tasks;
    1312
    1413namespace FarmatikoServices.Services
    … …  
    1615    public class ProcessJSONService : IProcessJSONService
    1716    {
    18         private IHealthFacilityRepository _healthFacilityRepository;
     17        //private IHealthFacilityRepository _healthFacilityRepository;
    1918        private IPandemicRepository _pandemicRepository;
    20         private IHealthcareWorkerRepository _healthcareWorkerRepository;
    21         private IMedicineRepository _medicineRepository;
    22         private readonly ILogger _logger;
    23         public ProcessJSONService(IHealthFacilityRepository healthFacilityRepository, IPandemicRepository pandemicRepository,
    24             IHealthcareWorkerRepository healthcareWorkerRepository, IMedicineRepository medicineRepository, ILogger logger)
     19        //private IHealthcareWorkerRepository _healthcareWorkerRepository;
     20        //private IMedicineRepository _medicineRepository;
     21        //private readonly ILogger _logger;
     22        public ProcessJSONService(/*IHealthFacilityRepository healthFacilityRepository, */IPandemicRepository pandemicRepository/*,
     23            IHealthcareWorkerRepository healthcareWorkerRepository, IMedicineRepository medicineRepository*/)
    2524        {
    26             _logger = logger;
    27             _healthFacilityRepository = healthFacilityRepository;
     25            //_logger = logger;
     26            //_healthFacilityRepository = healthFacilityRepository;
    2827            _pandemicRepository = pandemicRepository;
    29             _healthcareWorkerRepository = healthcareWorkerRepository;
    30             _medicineRepository = medicineRepository;
     28            //_healthcareWorkerRepository = healthcareWorkerRepository;
     29            //_medicineRepository = medicineRepository;
    3130        }
    32 
    33         public async Task<HashSet<HealthFacilities>> GetProcessedHealthFacilitiesFromJSON()
     31       
     32        public List<HealthFacilities> GetProcessedHealthFacilitiesFromJSON()
    3433        {
    3534            try
    3635            {
    37                 HashSet<HealthFacilities> hashSet = new HashSet<HealthFacilities>();
    38                 var client = new WebClient();
    39                 var json = client.DownloadString(@"C:\Users\dslez\Desktop\ustanovi.json");
     36                /*var client = new WebClient();
     37                var json = client.DownloadString(@"C:\Users\Miki\Desktop\ustanovi.json");
    4038
    4139                var jsonResponse = JObject.Parse(json);
    4240                var records = JArray.Parse(jsonResponse.GetValue("records").ToString());
    4341
    44                 foreach (var rec in records)
     42                foreach(var rec in records)
    4543                {
    4644                    dynamic obj = JsonConvert.DeserializeObject(rec.ToString());
    … …  
    5149                    var Phone = obj[11];
    5250                    var Type = obj[5];
    53                     HealthFacilities healthFacility = new HealthFacilities(Name, Municipality, Address, Type, Email, Phone);
    54                     /*healthFacility.Name = Name;
     51                    HealthFacilities healthFacility = new HealthFacilities();
     52                    healthFacility.Name = Name;
    5553                    healthFacility.Municipality = Municipality;
    5654                    healthFacility.Address = Address;
    5755                    healthFacility.Email = Email;
    5856                    healthFacility.Phone = Phone;
    59                     healthFacility.Type = Type;*/
    60                     //hashSet.Add(healthFacility);
    61                     await Task.Run(() => _healthFacilityRepository.Add(healthFacility));
     57                    healthFacility.Type = Type;
     58                    _healthFacilityRepository.Add(healthFacility);
     59                   
     60                }*/
    6261
    63                 }
    6462
    65             }
    66             catch (Exception e)
    67             {
    68                 _logger.LogInformation(e.Message);
    69                 throw new Exception("Cannot process health facilities from JSON.");
    70             }
    71             return null;
    72         }
    7363
    74         public async Task<HashSet<Pandemic>> GetProcessedPandemicsFromJSONApi()
    75         {
    76             try
    77             {
    78                 var client = new RestClient("https://api.covid19api.com/summary");
    79                 var response = client.Execute(new RestRequest());
     64                var client1 = new RestClient("https://api.covid19api.com/summary");
     65                var response = client1.Execute(new RestRequest());
    8066                string original = response.Content;
    8167                var jsonResponsePandemic = JObject.Parse(original);
    … …  
    9278                var NewMK = Int32.Parse(objP.GetValue("NewConfirmed").ToString());
    9379
    94                 var Name = "Coronavirus";
    95                 var ActiveMk = TotalMk - (TotalRecoveredMK + TotalDeathsMK);
    96                 var ActiveGlobal = TotalConfirmed - (TotalRecovered + TotalDeaths);
    97 
    98                 Pandemic pandemic = new Pandemic(Name, TotalMk, ActiveMk, TotalDeathsMK, NewMK, TotalConfirmed, TotalDeaths, ActiveGlobal);
    99                 /*pandemic.TotalGlobal = TotalConfirmed;
     80                Pandemic pandemic = new Pandemic();
     81                pandemic.TotalGlobal = TotalConfirmed;
    10082                pandemic.ActiveGlobal = TotalConfirmed - (TotalRecovered + TotalDeaths);
    10183                pandemic.DeathsGlobal = TotalDeaths;
    … …  
    10486                pandemic.DeathsMK = TotalDeathsMK;
    10587                pandemic.NewMK = NewMK;
    106                 pandemic.Name = "Coronavirus";*/
    107                 await Task.Run(() => _pandemicRepository.Add(pandemic));
    108             }
    109             catch (Exception e)
    110             {
    111                 _logger.LogInformation(e.Message);
    112             }
    113             return null;
    114         }
     88                pandemic.Name = "Coronavirus";
     89                _pandemicRepository.Add(pandemic);
    11590
    116         public async Task<HashSet<HealthcareWorkers>> GetProcessedHealthcareWorkersFromJSON()
    117         {
    118             try
    119             {
    120                 var client = new WebClient();
    121                 var jsonW = client.DownloadString(@"C:\Users\dslez\Desktop\rabotnici.json");
     91
     92
     93                /*var jsonW = client.DownloadString(@"C:\Users\Miki\Desktop\rabotnici.json");
    12294
    12395                var jsonResponseW = JObject.Parse(jsonW);
    … …  
    129101                    var Name = obj[4];
    130102                    var Branch = obj[2];
    131                     var FacilityName = obj[1];
     103                    HealthFacilities facility = new HealthFacilities();
     104                    facility.Name = obj[1];
     105                    facility.Municipality = "WorkerFacilityMunicipality";
     106                    facility.Address = "WorkerFacilityAddress";
    132107                    var Title = obj[3];
    133                     HealthFacilities facility = _healthFacilityRepository.GetByName(FacilityName);
    134                     HealthFacilities Facility = new HealthFacilities(facility.Name, facility.Municipality, facility.Address,
    135                                                                         facility.Type, facility.Email, facility.Phone);
    136                     HealthcareWorkers healthcareWorker = new HealthcareWorkers(Name, Branch, Facility, Title);
    137                     /*Facility.Name = obj[1];
    138                     Facility.Municipality = "WorkerFacilityMunicipality";
    139                     Facility.Address = "WorkerFacilityAddress";*/
    140                     /*healthcareWorker.Name = Name;
     108                    HealthcareWorkers healthcareWorker = new HealthcareWorkers();
     109                    healthcareWorker.Name = Name;
    141110                    healthcareWorker.Branch = Branch;
    142                     healthcareWorker.Facility = Facility;
    143                     healthcareWorker.Title = Title;*/
    144                     await Task.Run(() => _healthcareWorkerRepository.Add(healthcareWorker));
     111                    healthcareWorker.Facility = facility;
     112                    healthcareWorker.Title = Title;
     113                    _healthcareWorkerRepository.Add(healthcareWorker);
    145114                }
    146             }
    147             catch (Exception e)
    148             {
    149                 _logger.LogInformation(e.Message);
    150             }
    151             return null;
    152         }
    153115
    154         public async Task<HashSet<Medicine>> GetProcessedMedicinesFromJSON()
    155         {
    156             try
    157             {
    158                 var client = new WebClient();
    159                 var jsonM = client.DownloadString(@"C:\Users\dslez\Desktop\lekovi.json");
     116
     117
     118                var jsonM = client.DownloadString(@"C:\Users\Miki\Desktop\lekovi.json");
    160119
    161120                var jsonResponseM = JObject.Parse(jsonM);
    … …  
    172131                    var Price = float.Parse(obj[17]);
    173132                    var Packaging = obj[8];
    174                     Medicine medicine = new Medicine(Name, Strength, Form, WayOfIssuing, Manufacturer, Price, Packaging);
    175                     /*medicine.Name = Name;
     133                    Medicine medicine = new Medicine();
     134                    medicine.Name = Name;
    176135                    medicine.Strength = Strength;
    177136                    medicine.Form = Form;
    … …  
    179138                    medicine.Manufacturer = Manufacturer;
    180139                    medicine.Price = Price;
    181                     medicine.Packaging = Packaging;*/
    182                     await Task.Run(() => _medicineRepository.Add(medicine));
    183                 }
     140                    medicine.Packaging = Packaging;
     141                    _medicineRepository.Add(medicine);
     142                }*/
     143
     144
    184145            }
    185146            catch (Exception e)
    186147            {
    187                 _logger.LogInformation(e.Message);
     148                //_logger.LogError(e.Message);
     149                Console.WriteLine(e.Message);
     150                throw e;
     151                return null;
    188152            }
    189153            return null;
    190154        }
     155
    191156    }
    192157}
Note: See TracChangeset for help on using the changeset viewer.