<?php

namespace App\Http\Controllers;

use DateTime;
use App\Models\Link;
use App\Models\User;
use App\Models\Image;
use App\Models\Holiday;
use App\Models\Project;
use App\Models\Activity;
use App\Models\ReportK3;
use App\Jobs\ProcessSCurve;
use App\Models\AssignTools;
use App\Models\OfficeHours;
use App\Models\ProjectType;
use App\Models\ProjectPhase;
use App\Models\ProjectRisks;
use App\Models\UserToProyek;
use App\Models\VersionGantt;
use Illuminate\Http\Request;
use App\Models\HierarchyFtth;
use App\Models\ProjectIssues;
use App\Models\AssignMaterial;
use App\Models\DokumenProject;
use App\Models\ProjectCharter;
use App\Models\ReportActivity;
use App\Models\ShowHideColumn;
use App\Models\UserToActivity;
use App\Models\ActivityDokumen;
use App\Models\CommentActivity;
use App\Models\ProjectApproval;
use App\Models\RequestMaterial;
use App\Models\ProjectMileStone;
use App\Models\ProjectChecklists;
use Illuminate\Support\Facades\DB;
use App\Models\ProjectParticipants;
use App\Models\FolderDocumentProyek;
use App\Models\ProjectToChecklistK3;
use App\Helpers\MasterFunctionsHelper;
use App\Models\ReportActivityMaterial;
use Illuminate\Support\Facades\Artisan;

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;

		if(empty($data['phase_id']))
			$data['phase_id'] = 1;

		$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::query()
            ->from('m_proyek AS mp')
            ->where('mp.id', $id)
            ->selectRaw('value_proyek,scoupe_of_work,kode_sortname,jumlah_stakeholder,nama,mulai_proyek,akhir_proyek,area_kerja,rencana_biaya,biaya_actual,company,pm_id,type_proyek_id,divisi_id,persentase_progress,keterangan,durasi_proyek,progress_by_worklog,currency_symbol,late_consequence,assumtion,currency_code,currency_name,project_objectives,considered_success_when,potential_risk,testing_environment,budget_health,phase_id,calculation_status');

        if (!is_null($result->first()['divisi_id'])) {
            $result->leftJoin('m_divisi', 'mp.divisi_id', '=', 'm_divisi.id')
            ->addSelect(DB::raw('m_divisi.name AS nama_divisi'));
        }

        $result = $result->first();

		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();
		ProjectChecklists::where('proyek_id', $project_id)->delete();
		ProjectIssues::where('proyek_id', $project_id)->delete();
		ProjectRisks::where('proyek_id', $project_id)->delete();
        ProjectToChecklistK3::where('proyek_id', $project_id)->delete();
        HierarchyFtth::where('project_id', $project_id)->delete();
        AssignTools::where('proyek_id', $project_id)->delete();
        OfficeHours::where('proyek_id', $project_id)->delete();
        ReportK3::where('proyek_id', $project_id)->delete();
        RequestMaterial::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'];
        // $builder->where("selfTable.created_by",$this->currentName);
		$dataGet = $builder->get();
		$totalRecord = $countBuilder->count();

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

	public function list()
	{
		$data = Project::select(
			'id',
			'kode_sortname',
			'jumlah_stakeholder',
			'nama',
			'mulai_proyek',
			'akhir_proyek',
			'area_kerja',
			'lokasi_kantor',
			'rencana_biaya',
			'biaya_actual',
			'company',
			'pm_id',
			'type_proyek_id',
			'divisi_id',
			'persentase_progress',
			'keterangan',
			'durasi_proyek',
			'progress_by_worklog',
			'status',
			'currency_symbol',
			'currency_code',
			'currency_name',
			'project_objectives',
			'considered_success_when',
			'potential_risk',
			'testing_environment',
			'currency_code',
			'currency_symbol',
			'currency_name',
			'budget_health',
			'phase_id',
			'calculation_status',
			'created_at',
			'created_by',
			'updated_at',
			'updated_by'
        )->orderBy('id', 'desc')
         // ->where("created_by",$this->currentName)
         ->get();
		$countData = $data->count();

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

        $totalPlannedCost = array_sum(array_map('intval', array_column($data->toArray(), 'plannedCost')));
        $totalActualCost = $data->sum('actualCost');
		$manpowers = User::count();
		$projectsOnDanger = Project::where('budget_health', 'overrun')->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(m_type_proyek.id) 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 getSCurve(Request $request){
		$data = MasterFunctionsHelper::getSCurve($request);
		return response()->json(['status'=>'success','code'=>200, 'data' => $data], 200);
  }

//   testing
  public function calculateSCurvetest(Request $request){
	$data = MasterFunctionsHelper::calculateSCurve($request->project_id);
	return response()->json(['status'=>'success','code'=>200, 'data' => $data], 200);
}

  public function calculateSCurve(Request $request){
    $sCurve = Project::select('scurve')->where('id', $request->project_id)->first();
		return response()->json(['status'=>'success','code'=>200, 'data' => json_decode($sCurve->scurve)], 200);
  }

  public function sCurveCommand(Request $request){
	Artisan::call('calculate:scurve', [
		'project_id' => $request->project_id
	]);
    // $project = Project::find($request->project_id);

    // if ($project) {
    //     dispatch(new ProcessSCurve($project));

    //     return response()->json(['message' => 'S Curve calculation queued']);
    // }

    // return response()->json(['message' => 'Project not found'], 404);
  }

  public function getLinearSCurve(Request $request){
		$data = MasterFunctionsHelper::getLinearSCurve($request);
		return response()->json(['status'=>'success','code'=>200, 'data' => $data], 200);
	}

	public static function setSyncDate($activity_id, $activity, $report) {
		$status = AssignMaterial::where('activity_id', $activity_id)->first();
		if (!isset($status)) {
			$reports = array(
				'activity_id' => $activity_id,
				'min_date' => new DateTime($activity->start_date),
				'max_date' => new DateTime($activity->end_date),
				'status' => 'open'
			);
			return $reports;
		}
		if (!isset($status->status_activity)) {
			$status->status_activity = 'open';
		}
		if ($status->status_activity != 'done') {
			$minDate = date_create($report->report_date);
			$maxDate = date_create($report->report_date);
			date_add($maxDate, date_interval_create_from_date_string($activity->duration . " days"));
		} else {
			$material = AssignMaterial::where('activity_id', $activity_id)->first();
			$minDate = date_create($material->start_activity);
			$maxDate = date_create($material->finish_activity);
		}
		$reports = array(
			'activity_id' => $activity_id,
			'min_date' => $minDate,
			'max_date' => $maxDate,
			'status' => $status->status_activity
		);
		return $reports;
	}

  public function synchronizeReport($gantt_id)
	{
		$activities = Activity::where("version_gantt_id", $gantt_id)->get();
		$reports = [];

		foreach($activities as $activity) {
			$activity_id = $activity->id;
			$countReports = ReportActivityMaterial::where('activity_id', $activity_id)->count();
			if ($countReports === 1) {
				$dataReports = ReportActivityMaterial::where('activity_id', $activity_id)->orderBy('report_date')->get();
				foreach($dataReports as $dr) {
					$reports[] = ProjectController::setSyncDate($activity_id, $activity, $dr);
				}
			}
			if ($countReports > 1) {
				$firstReport = ReportActivityMaterial::where('activity_id', $activity_id)->orderBy('report_date')->first();
				$reports[] = ProjectController::setSyncDate($activity_id, $activity, $firstReport);
			}
			$successor = Link::where('t_activity_id', $activity->id)->first();
			if ($successor) {
				$predecessor = Activity::find($successor->s_activity_id);
				$activity->start_date = $predecessor->end_date;
				$end_date = new DateTime($activity->start_date);
				$end_date->modify("+" . $activity->duration . " days");
				$activity->end_date = $end_date->format("Y-m-d H:i:sO");
			}
			$activity->save();
		}
		/* return response()->json(['status'=>'success','data'=> $reports,'code'=>200], 200); */
		/* return response()->json(['status'=>'success','data'=> $activities,'code'=>200], 200); */

		for ($i=0; $i < count($reports); $i++) {
			$activity = Activity::find($reports[$i]['activity_id']);
			if($reports[$i]['status'] != 'done'){
				$reports[$i]['max_date']->modify('-1 day');
			}else if($reports[$i]['status'] == 'done'){
				$activity->actual_end = $reports[$i]['max_date']->setTime(23,59,59);
			}
			$activity->start_date = $reports[$i]['min_date'];  					//same early
			$activity->end_date = $reports[$i]['max_date']->setTime(23,59,59); 	// same early
			$startDate = new DateTime($activity->start_date);
			$endDate = new DateTime($activity->end_date);
			$duration = MasterFunctionsHelper::countDays($activity->version_gantt_id, $startDate, $endDate);
			$activity->duration = $duration;
			$activity->actual_start = $reports[$i]['min_date'];
			$activity->save();
		}

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

	public function setBaseline($gantt_id)
	{
		$activities = Activity::where("version_gantt_id", $gantt_id)->get();

		foreach ($activities as $activity) {
			$activity->update([
				"planned_start"=>$activity->start_date,
				"planned_end"=>$activity->end_date,
				"early_start"=>$activity->start_date,
				"early_end"=>$activity->end_date,
			]);
		}

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

  public function getInvoiceIntegration(Request $request) {
        $ganttCount = VersionGantt::where('proyek_id', $request->id)->count();
		$search = urlencode($request->search);
		if(empty($search))
			return response()->json(['status'=>'error', 'message'=>'Empty query string!'], 400);
		$url = str_replace("SEARCH", $search, config('api.adw').'/project_cost?project_no=SEARCH');

		$response = MasterFunctionsHelper::curlReq($url);
        if (isset($request->gantt_id)) {
            $response->data->total_cost = $response->data->total_cost / $ganttCount;
        }

		return response()->json(['status'=>'success', 'data'=> $response, 'code'=>200], 200);
	}
    public function getByUser($id)
    {
        $alias = "utp";
        $userProyek = UserToProyek::query()
        ->from('assign_hr_to_proyek AS ' . $alias)
        ->where([
            ['is_customer', true],
            ['user_id', $id]
        ])
        ->leftJoin('m_users', $alias.'.user_id', '=', 'm_users.id')
        ->leftJoin('m_proyek', $alias.'.proyek_id', '=', 'm_proyek.id')
        ->leftJoin('m_type_proyek', 'm_proyek.type_proyek_id', '=', 'm_type_proyek.id')
        ->select('m_proyek.*', 'm_type_proyek.name AS join_second_name','m_users.name AS join_first_name')
        ->get();
        $totalRecord = $userProyek->count();

        return response()->json(['status' => 'success', 'code' => 200, 'data' => $userProyek, 'totalRecord' => $totalRecord], 200);
    }
  public function detail(Request $request, $id, $gantt_id = null, $s_curve = null){
		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);
        if (!isset($gantt_id)) {
            $gantt = MasterFunctionsHelper::getLatestGantt($id);
            $ganttId = $gantt['last_gantt_id'];
        } else {
            $ganttId = $gantt_id;
        }
		$result->projectManager = User::where('id', $result->pm_id)->value('name');

        if (isset($s_curve)) {
            $result->header = Activity::whereNull('parent_id')->where("proyek_id", $id)->first();
            $actualStartExist = Activity::where('proyek_id', $id)->whereNotNull('actual_start')->exists();
            if($result['type_proyek_id'] === 9)
            {
                $actualEndExist = Activity::where('proyek_id', $id)->exists();
                $query = Activity::where('proyek_id', $id);
            }else{
                $actualEndExist = Activity::where('version_gantt_id', $ganttId)->exists();
                $query = Activity::where('version_gantt_id', $ganttId);
            }
        } else {
            $result->header = Activity::whereNull('parent_id')->where("proyek_id", $id)->where("version_gantt_id", $ganttId)->first();
            $actualStartExist = Activity::where('version_gantt_id', $ganttId)->whereNotNull('actual_start')->exists();
            $actualEndExist = Activity::where('version_gantt_id', $ganttId)->exists();
            $query = Activity::where('version_gantt_id', $ganttId);
        }

        if ($actualStartExist) {
            $startDate = $query->orderBy('actual_start')->value('start_date');
        } else {
            $startDate = $query->orderBy('start_date')->value('start_date');
        }
        if($actualEndExist)
        {
            $maxEndDate = $query->max('id');
            $endDate = $query->where('id',$maxEndDate)->first()->end_date;
        }

        $plannedStart = Activity::where('version_gantt_id', $ganttId)
				->orderBy('planned_start')
				->value('planned_start');
        $plannedEnd = Activity::where('version_gantt_id', $ganttId)
				->orderByDesc('planned_end')
				->value('planned_end');
        $result->header->start_date = $startDate;
        $result->header->end_date = $endDate;
        $result->header->planned_start = $plannedStart;
        $result->header->planned_end = $plannedEnd;
		return response()->json(['status'=>'success','code'=> 200,'data'=>$result, 'gantt'=>$ganttId], 200);
	}

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

		$result = Project::find($payload['id']);

		if(!$result)
			return response()->json(['status'=>'failed','message'=> 'Project not found!','code'=> 404], 404);
		//TODO possible overdue bug
		$endDate = Activity::where('proyek_id', $payload['id'])
			->orderByDesc('end_date')
			->value('end_date');
		if(isset($payload['till_date'])) {
			if (isset($payload['scurve'])) {
				$overdueActivities = Activity::where('proyek_id', $payload['id'])->whereNotNull('parent_id')->where('persentase_progress', '!=', 100)->whereDate('end_date','<=',$endDate)->orderBy('end_date', 'asc')->get();
			} else {
				$overdueActivities = Activity::where('version_gantt_id', $payload['gantt'])->whereNotNull('parent_id')->where('persentase_progress', '!=', 100)->whereDate('end_date','<=',$endDate)->orderBy('end_date', 'asc')->get();
			}
		}
		else {
			if (isset($payload['scurve'])) {
				$overdueActivities = Activity::where('proyek_id', $payload['id'])->whereNotNull('parent_id')->where('persentase_progress', '!=', 100)->orderBy('end_date', 'asc')->get();
			} else {
				$overdueActivities = Activity::where('version_gantt_id', $payload['gantt'])->whereNotNull('parent_id')->where('persentase_progress', '!=', 100)->orderBy('end_date', 'asc')->get();
			}
		}
		$result->overdueActivities = $overdueActivities;

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

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

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

		$reports = DB::table('assign_material_to_activity as ama')
			->select('u.name', 'a.name as activity_name', 'ama.qty_planning', 'ram.qty as qty_real','rm.description as material_name', 'rm.uom as material_unit',
			   	'ram.lat', 'ram.lon', 'ram.description as report_notes', 'ram.report_date')
			->join('report_activity_material as ram', 'ram.assign_material_id', '=', 'ama.id')
			->join('m_req_material as rm', 'rm.id', '=', 'ama.material_id')
			->join('m_activity as a', 'a.id', '=', 'ama.activity_id')
			->join('m_users as u', 'u.id', '=', 'ram.user_id')
			->where('ama.proyek_id', '=', $payload['project_id'])
			->whereNotNull('ram.lat')
      ->whereBetween('ram.report_date', [$payload['start_date'], $payload['end_date']]);

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

  public function getManpower($proyek_id){
		$manCount = UserToProyek::where('proyek_id', $proyek_id)->count();
		return response()->json(['totalRecord'=>$manCount]);
	}

  public function getAssignedHR($gantt_id){
		$results = UserToActivity::select('assign_hr_to_activity.proyek_id', 'assign_hr_to_activity.user_id', 'm_activity.id', 'm_activity.name', 'm_activity.start_date', 'm_activity.end_date')
			->join('m_activity', 'm_activity.id', '=', 'assign_hr_to_activity.activity_id')
			->where('assign_hr_to_activity.version_gantt_id', $gantt_id)
			->get();
		return response()->json(['data'=>$results]);
	}

	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)
					->first();

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

		$manpowers = UserToProyek::where('proyek_id', $id)->count();
		$rootActivity = Activity::whereNull('parent_id')->where('proyek_id', $id)->orderBy('version_gantt_id', 'desc')->first();

		$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();

		$data->actual_cost = $actualCost;
		$data->progress = $progress;
		$data->comment = $commentActivity;
		$data->man_power = $manpowers;

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

	private function httpReq($search){
	    $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, str_replace("ADDR", $search, API_GEOLOCATION));

        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
		curl_setopt($ch, CURLOPT_VERBOSE, true);
		curl_setopt($ch, CURLOPT_STDERR, fopen('php://stderr', 'w'));

		$info = curl_getinfo($ch);

        $output = curl_exec($ch);
        curl_close($ch);

        return json_decode($output);
	}

}