first commit

2026-06-16 10:45:41 +07:00
commit ccecc0bc6b
144 changed files with 124547 additions and 0 deletions
--- a/dashboard/app/Services/DataRetrievalService.php
+++ b/dashboard/app/Services/DataRetrievalService.php
@@ -0,0 +1,150 @@
+<?php
+
+namespace App\Services;
+
+use Illuminate\Http\Client\RequestException;
+use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Facades\Http;
+use Illuminate\Support\Facades\Log;
+
+class DataRetrievalService
+{
+
+    protected $apiBaseUrl;
+    protected $apiUsername;
+    protected $apiPassword;
+
+    public function __construct()
+    {
+        $this->apiBaseUrl = config('services.nphl_api.url');
+        $this->apiUsername = config('services.nphl_api.username');
+        $this->apiPassword = config('services.nphl_api.password');
+    }
+
+    public function get($endpoint)
+    {
+        try {
+
+            $ch = curl_init();
+            curl_setopt($ch, CURLOPT_URL, $this->apiBaseUrl . $endpoint);
+            curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
+            curl_setopt($ch, CURLOPT_ENCODING, '');
+            curl_setopt($ch, CURLOPT_MAXREDIRS, 10);
+            curl_setopt($ch, CURLOPT_TIMEOUT, 0);
+            curl_setopt($ch, CURL_HTTP_VERSION_1_1, 0);
+            curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "GET");
+            curl_setopt($ch, CURLOPT_HTTPAUTH, CURLAUTH_BASIC);
+            curl_setopt($ch, CURLOPT_HTTPHEADER, array('Content-Type: application/json'));
+            curl_setopt($ch, CURLOPT_USERPWD, $this->apiUsername . ":" . $this->apiPassword);
+            $resp = curl_exec($ch);
+            $b="";
+            if($e = curl_error($ch)){
+                $b= $e;
+            }else{
+                $b= $resp;
+            }
+            curl_close($ch);
+            return $b;
+
+        } catch (RequestException $e) {
+            return [
+                'error' => true,
+                'message' => $e->getMessage(),
+                'status' => optional($e->response)->status()
+            ];
+        }
+    }
+
+
+    public function getSurveillanceData()
+    {
+        try{
+            $lookbackDays = config('app.lookback_days');
+            $surveillances = DB::connection('mysql')->select("select * from surveillances");
+            foreach ($surveillances as $surveillance){
+                $surveillance_data = $this->get('api/labsurveil.php?surveillance_id='.$surveillance->id.'&start_date='.now()->subDays($lookbackDays[$surveillance->code])->toDateString());
+                $data = json_decode(preg_replace('/^\x{FEFF}+/u', '', $surveillance_data));
+                @$this->insert_surveillance_cases((array)$data->laboratory_cases);
+                @$this->insert_surveillance_case_lab_results((array)$data->laboratory_results);
+
+            }
+
+            Log::channel('jobs')->info(now()->toDateString(). ' Service Reload Data Successfully Ran');
+            return true;
+        }
+        catch (\Exception $e){
+            Log::channel('jobs')->error($e->getMessage());
+            return false;
+        }
+
+    }
+
+    private function insert_surveillance_cases($cases){
+
+        $case_data = [];
+        foreach ($cases as $case) {
+            $case_data[] = [
+                'lab_code'          => $case->labcode,
+                'case_date'          => $case->patdate,
+                'is_newcase'        => $case->isnewcase,
+                'sentinel_site_name'       => $case->labname_en,
+                'site_province_name'    => $case->labaddress_en,
+                'surveillance_id'  => $case->surveillance_id,
+                'year_data'        => $case->year_data,
+                'week_data'        => $case->week_data,
+                'patient_age_inday'           => $case->patage,
+                'patient_sex'           => $case->patsex,
+                'is_alive'         => $case->is_alive,
+                'patient_province'       => $case->proname_en
+            ];
+        }
+
+        $case_chunks = array_chunk($case_data, 500);
+        foreach ($case_chunks as $chunk) {
+            DB::connection('mysql')->table('surveillance_cases')->upsert($chunk, [
+                'lab_code',
+                'surveillance_id'
+            ], [
+                'case_date',
+                'is_newcase',
+                'sentinel_site_name',
+                'site_province_name',
+                'year_data',
+                'week_data',
+                'patient_age_inday',
+                'patient_sex',
+                'is_alive',
+                'patient_province'
+            ]);
+        }
+    }
+
+    private function insert_surveillance_case_lab_results($lab_results){
+        $result_data = [];
+        foreach ($lab_results as $lab_result) {
+            $result_data[] = [
+                'lab_code'          => $lab_result->labcode,
+                'surveillance_id'  => $lab_result->surveillance_id,
+                'is_positive'        => $lab_result->is_positive,
+                'pathogen_name'        => $lab_result->pathogen_name,
+                'subtype'           => $lab_result->subtype,
+                'indicator'           => $lab_result->indicator
+            ];
+        }
+        $result_chunks = array_chunk($result_data, 500);
+        foreach ($result_chunks as $chunk) {
+            DB::connection('mysql')->table('case_lab_results')->upsert($chunk,
+                [
+                    'lab_code',
+                    'surveillance_id',
+                    'indicator'
+                ],
+                [
+                    'is_positive',
+                    'pathogen_name',
+                    'subtype'
+                ]);
+        }
+    }
+
+}