<?php

namespace App\Http\Controllers;

use Illuminate\Http\Request;
use App\Models\Project;
use App\Models\UserToProyek;
use App\Models\Activity;
use App\Models\UserToActivity;
use App\Models\User;
use App\Models\AssignMaterial;
use App\Models\DokumenProject;
use App\Models\FolderDocumentProyek;
use App\Models\ProjectCharter;
use App\Models\ProjectApproval;
use App\Models\ProjectPhase;
use App\Models\ProjectType;
use App\Models\ProjectMileStone;
use App\Models\ProjectParticipants;
use App\Models\ShowHideColumn;
use App\Models\VersionGantt;
use App\Models\Image;
use App\Models\CommentActivity;
use App\Models\Link;
use App\Models\ActivityDokumen;
use App\Models\Holiday;
use App\Models\ReportActivity;
use App\Models\OfficeHours;
use DB;

const API_GEOLOCATION = "https://nominatim.oslogdev.com/search/ADDR?format=json&addressdetails=1&limit=1";

class ProjectController extends Controller
{

	public function add(Request $request)
	{
		$this->validate($request, [
			'nama' => 'required',
			'mulai_proyek' => 'required',
			'akhir_proyek' => 'required',
			'rencana_biaya' => 'required',
			'type_proyek_id' => 'required'
		]);

		$data = $request->all();

		$data['created_by'] = $this->currentName;

		$result = Project::create($data);

		if(!$result)
			return response()->json(['status'=>'failed','message'=>'Failed to add data!','code'=> 500], 500);

		$this->createOfficeHours($result->id);
		$dataResultInsert = Project::where('nama', $data['nama'])->where('mulai_proyek', $data['mulai_proyek'])->first();

		return response()->json(['status'=>'success','message'=>'Data added!', 'data_result' =>$dataResultInsert, 'code'=> 200], 200);
	}

	public function edit($id){
		if(empty($id) || !is_int((int)$id))
			return response()->json(['status'=>'failed','message'=>'id is required!','code'=>400], 400);

		$result = Project::find($id);

		if(!$result)
			return response()->json(['status'=>'failed','message'=> 'Data not found!','code'=> 404], 404);

		return response()->json(['status'=>'success','code'=> 200,'data'=>$result], 200);
	}

	public function update(Request $request, $id)
	{
		if(empty($id) || !is_int((int)$id))
			return response()->json(['status'=>'failed','message'=>'id is required!','code'=>400], 400);

		$data = Project::find($id);

		if(!$data)
			return response()->json(['status'=>'failed','message'=> 'Data not found!','code'=> 404], 404);

		$result = $data->update($request->all());

		if(!$result)
			return response()->json(['status'=>'failed','message'=> 'Failed to update!','code'=> 500], 500);

		return response()->json(['status'=>'success','message'=>'Data updated!','code' => 200], 200);
	}

	private function createOfficeHours($proyek_id)
	{
		$dataCreate = array(
			"proyek_id"=>$proyek_id,
			"monday_start"=> "08:00:00",
			"monday_end"=> "16:00:00",
			"tuesday_start"=> "08:00:00",
			"tuesday_end"=> "16:00:00",
			"wednesday_start"=> "08:00:00",
			"wednesday_end"=> "16:00:00",
			"thursday_start"=> "08:00:00",
			"thursday_end"=> "16:00:00",
			"friday_start"=> "08:00:00",
			"friday_end"=> "16:00:00",
			"saturday_start"=> "08:00:00",
			"saturday_end"=> "16:00:00",
			"sunday_start"=> "08:00:00",
			"sunday_end"=> "16:00:00",
			"created_by"=> $this->currentName
		);

		OfficeHours::create($dataCreate);

		return true;
	}

	public function delete($id)
	{
		$data = Project::find($id);

		if(!$data)
			return response()->json(['status'=>'failed','message'=>'Data not found!','code'=> 404], 404);

		$this->deleteRelative($id);

		if(!$data->delete())
			return response()->json(['status'=>'failed','message'=>'Delete failed!','code'=> 500], 500);

		return response()->json(['status'=>'success','message'=>'Data deleted!','code'=>200], 200);
	}

	private function deleteRelative($project_id)
	{
		UserToProyek::where('proyek_id', $project_id)->delete();
		UserToActivity::where('proyek_id', $project_id)->delete();
		AssignMaterial::where('proyek_id', $project_id)->delete();
		ProjectCharter::where('proyek_id', $project_id)->delete();
		ProjectApproval::where('proyek_id', $project_id)->delete();
		ProjectMileStone::where('proyek_id', $project_id)->delete();
		ProjectParticipants::where('proyek_id', $project_id)->delete();
		$this->deleteVersionGantt($project_id);
		$this->deleteDokumenProject($project_id);
	}

	private function deleteVersionGantt($project_id)
	{
		$dataVg = VersionGantt::where("proyek_id", $project_id)->pluck("id");
		$vhIds = $dataVg->all();
		$activity = Activity::whereIn("version_gantt_id", $vhIds)->pluck('id');
		$activityIds = $activity->all();
		$dataRa = ReportActivity::whereIn("activity_id", $activityIds)->get();
		foreach ($dataRa as $ra) {
			$images = Image::where("ref_id", $ra->id)->where("category", "report_activity")->get();
			foreach ($images as $image) {
				if(file_exists($this->pathImage.$image->image)){
					unlink($this->pathImage.$image->image);
				}
			}
			Image::where("ref_id", $ra->id)->where("category", "report_activity")->delete();
		}
		$dataAd = ActivityDokumen::whereIn("activity_id", $activityIds)->get();
		foreach ($dataAd as $ad) {
			if(file_exists($this->pathActivityDocument.$ad->file)){
				unlink($this->pathActivityDocument.$ad->file);
			}
		}
		ActivityDokumen::whereIn("activity_id", $activityIds)->delete();
		CommentActivity::whereIn("activity_id", $activityIds)->delete();
		Holiday::where("proyek_id", $project_id)->delete();
		VersionGantt::where("proyek_id", $project_id)->delete();
		Link::whereIn("version_gantt_id", $vhIds)->delete();
		ShowHideColumn::whereIn("version_gantt_id", $vhIds)->delete();
		Activity::whereIn("version_gantt_id", $vhIds)->delete();
		ReportActivity::whereIn("activity_id", $activityIds)->delete();
	}

	private function deleteDokumenProject($project_id)
	{
		$dataDokumen = DokumenProject::where("type_dokumen", "project-document-out-folder")->where('ref_id', $project_id)->get();

		foreach ($dataDokumen as $dokumen) {
			if(file_exists($this->pathDocument.$dokumen->file)){
				unlink($this->pathDocument.$dokumen->file);
			}
		}
		DokumenProject::where("type_dokumen", "project-document-out-folder")->where('ref_id', $project_id)->delete();

		$dataFolder = FolderDocumentProyek::where('proyek_id', $project_id)->pluck("id");
		$ref_ids = $dataFolder->all();
		$dataDokumen = DokumenProject::where("type_dokumen", "project-document-in-folder")->whereIn('ref_id', $ref_ids)->get();
		foreach ($dataDokumen as $dokumen) {
			if(file_exists($this->pathDocument.$dokumen->file)){
				unlink($this->pathDocument.$dokumen->file);
			}
		}

		DokumenProject::where("type_dokumen", "project-document-in-folder")->whereIn('ref_id', $ref_ids)->delete();
	}

	public function search(Request $request)
	{
		$payload = $request->all();

		$dataBuilder = $this->setUpPayload($payload, 'm_proyek');
		$builder = $dataBuilder['builder'];
		$countBuilder = $dataBuilder['count'];
		$dataGet = $builder->get();
		$totalRecord = $countBuilder->count();

		return response()->json(['status'=>'success','code'=>200,'data'=>$dataGet, 'totalRecord'=>$totalRecord], 200);
	}

	public function list()
	{
		$data = Project::orderBy('id', 'desc')->get();
		$countData = $data->count();

		if(!$data)
			return response()->json(['status'=>'failed','message'=>'Data not found!','code'=> 404], 404);

		$scheduleWarningThreshold = 10;
		$scheduleDangerThreshold = 5;
		foreach($data as $d){
			$progress = $costVariance = $actualCost = 0;
			$lastActivity = null;
			$scheduleHealth = "on-track";
			$rootActivity = Activity::whereNull('parent_id')->where('proyek_id', $d->id)->orderBy('version_gantt_id', 'desc')->first();
			if($rootActivity){
				$costVariance = $d->rencana_biaya - $rootActivity->biaya_actual;
				$actualCost = $rootActivity->biaya_actual ?? 0;
				$progress = $rootActivity->persentase_progress ?? 0;

				$timeleft = strtotime($d->mulai_proyek) - strtotime($rootActivity->end_date);
				$date1 = new \DateTime(date("Y-m-d", strtotime($d->mulai_proyek)));
				$date2 = new \DateTime(date("Y-m-d", strtotime($rootActivity->end_date)));
				$daysRemaining = $date2->diff($date1);
				$daysRemaining = $daysRemaining->d;

				if($daysRemaining <= $scheduleDangerThreshold) {
					$scheduleHealth = "danger";
				} elseif ($daysRemaining <= $scheduleWarningThreshold) {
					$scheduleHealth = "warning";
				}
				$lastActivity = date("d/m/Y", strtotime($rootActivity->end_date));
			}
			$d->plannedInterval = date("d/m/Y", strtotime($d->mulai_proyek)) . " - " . date("d/m/Y", strtotime($d->akhir_proyek));
			$d->plannedCost = $d->rencana_biaya;
			$d->actualCost = $actualCost;
			$d->lastActivity = $lastActivity ?? "-";
			$d->costVariance = $costVariance;
			$d->costHealth = $d->budget_health;
			$d->scheduleHealth = $scheduleHealth;
			$d->progress = $progress;
			$d->lastGanttId = VersionGantt::where("proyek_id", $d->id)->orderBy('id', 'desc')->first()->id ?? null;
			$d->manpower = UserToProyek::where("proyek_id", $d->id)->count() ?? 0;
            $d->projectManager = DB::table('m_proyek')
                     ->join('m_users', 'm_users.id', '=', 'm_proyek.pm_id')
                     ->where('m_proyek.id', $d->id)
                     ->pluck('m_users.name')
                     ->first();
            if($d->area_kerja != ''){
                $d->geolocation = $this->httpReq($d->area_kerja);
            } else {
                $d->geolocation = '';
            }
        }
    
        $totalPlannedCost = $data->sum('plannedCost');
        $totalActualCost = $data->sum('actualCost');
		$manpowers = User::count();
		$projectsOnDanger = Project::where('budget_health', 'danger')->count();
        $projectPhases = ProjectPhase::orderBy('order', 'asc')->pluck('name');
        $projectTypes = ProjectType::orderBy('id', 'asc')->pluck('name');
        try {
            $projectsByPhase = DB::table('m_proyek')
                     ->select('m_proyek_phase.name', 'm_proyek_phase.color', DB::raw('count(*) as total'))
                     ->join('m_proyek_phase', 'm_proyek_phase.id', '=', 'm_proyek.phase_id')
                     ->groupBy('m_proyek_phase.name', 'm_proyek_phase.color')
                     ->get();
        } catch (\Exception $e) {
            return response()->json(['message' => $e->getMessage()]);
        }
        try {
            $projectsByType = DB::table('m_proyek')
                     ->select('m_type_proyek.name', DB::raw('count(*) as total'))
                     ->join('m_type_proyek', 'm_type_proyek.id', '=', 'm_proyek.type_proyek_id')
                     ->groupBy('m_type_proyek.name')
                     ->get();
        } catch (\Exception $e) {
            return response()->json(['message' => $e->getMessage()]);
        }

		return response()->json(
		    [
		        'status'=>'success',
		        'code'=>200,
		        'data'=>$data,
		        'totalRecord'=>$countData,
		        'totalPlannedCost' => $totalPlannedCost,
		        'totalActualCost' => $totalActualCost,
		        'totalRevenue' => $totalPlannedCost - $totalActualCost,
		        'manpowers' => $manpowers,
		        'projectsOnDanger'=> $projectsOnDanger,
		        'projectPhases' => $projectPhases,
		        'projectsByPhase' => $projectsByPhase,
		        'projectTypes' => $projectTypes,
		        'projectsByType' => $projectsByType,
	        ], 200);
	}

	public function getListProjectTask($id){
		$data = UserToActivity::select("assign_hr_to_activity.user_id as user_id","m_proyek.*")
			->where("assign_hr_to_activity.user_id", $id)
			->join('m_proyek', 'assign_hr_to_activity.proyek_id', '=', 'm_proyek.id')
			->groupBy("m_proyek.proyek_id")
			->get();

		if(!$data)
			return response()->json(['status'=>'failed','message'=>'Data not found!','code'=> 404], 404);

		return response()->json(['status'=>'success','code'=>200,'data'=>$data], 200);
	}

	public function dashboard($id)
	{ 
		$data = DB::table('m_proyek as mp')
					->select('mp.kode_sortname', 'mp.nama as name_project', 'mp.mulai_proyek as start', 'mp.akhir_proyek as finish', 
							'mp.rencana_biaya', 'mp.company', 'mp.currency_symbol', 'mu.name as pm', 'mp.budget_health')
					->join('m_users as mu', 'mu.id', '=', 'mp.pm_id')
					->where('mp.id', $id)
					->get(); 
		$countData = $data->count(); 

		$manpowers = UserToProyek::where('proyek_id', $id)->count();
		$rootActivity = Activity::whereNull('parent_id')->where('proyek_id', $id)->orderBy('version_gantt_id', 'desc')->first();
		
		if($rootActivity){
			$actualCost = $rootActivity->biaya_actual ?? 0;
			$progress = $rootActivity->persentase_progress ?? 0;
		}

		$commentActivity = DB::table('m_comment_activity as mca')
								->select('mca.activity_id', 'mca.comment as comment', 'mca.created_by as comment_by', 'mca.created_at as comment_created',
										 'ma.name as activity')
								->join('m_activity as ma', 'ma.id', '=', 'mca.activity_id')
								->where('ma.proyek_id', $id)
								->orderBy('comment_by')
								->take(2)
								->get();

		foreach ($data as $val) {
			$dataRes['kode_sortname'] = $val->kode_sortname;
			$dataRes['name_project'] = $val->name_project;
			$dataRes['start'] = $val->start;
			$dataRes['finish'] = $val->finish;
			$dataRes['rencana_biaya'] = $val->rencana_biaya;
			$dataRes['company'] = $val->company;
			$dataRes['currency_symbol'] = $val->currency_symbol;
			// get firstname
			$arr = explode(" ", $val->pm);
			$dataRes['pm'] = $arr[0];
			$dataRes['budget_health'] = $val->budget_health;
			$dataRes['actual_cost'] = $actualCost;
			$dataRes['progress'] = $progress;
			$dataRes['comment'] = $commentActivity;
			$dataRes['man_power'] = $manpowers;
		} 
		
		if(!$data)
			return response()->json(['status'=>'failed','message'=>'Data not found!','code'=> 404], 404); 

		return response()->json(['status'=>'success','code'=>200,'data'=>$dataRes, 'totalRecord'=>$countData], 200);
	}
	
	private function httpReq($search){
	    $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, str_replace("ADDR", $search, API_GEOLOCATION));
        
        // SSL important
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        //curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
        
        $output = curl_exec($ch);
        curl_close($ch);
    
        return json_decode($output);
	}
	
}