surveyor_indonesia_backend/app/Http/Controllers/DashboardBoDController.php

<?php

namespace App\Http\Controllers;

use App\Helpers\MasterFunctionsHelper;
use App\Models\Divisi;
use App\Models\Project;
use App\Models\ProjectPhase;
use App\Models\User;
use App\Models\UserToVersionGantt;
use Illuminate\Support\Collection;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;

class DashboardBoDController extends Controller
{
	private function interpolateYear($year)
	{
		if ($year)
			$year = '%' . $year . '%';
		return $year;
	}

	private function curlReq($url, $token)
	{
		$ch = curl_init();
		$headers = [
			'Authorization: ' . $token
		];
		curl_setopt($ch, CURLOPT_URL, $url);
		curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
		curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);

		$response = curl_exec($ch);
		if ($response === false)
			$response = curl_error($ch);
		curl_close($ch);

		return json_decode($response);
	}

	private function getInvoiceIntegration($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');
		$token = config('api.adw_token');
		$response = $this->curlReq($url, $token);

		if (@$response->data->project_no == "")
			return null;

		return $response;
	}

	// OLD
	// public function getCompanyCashFlow($year = '%')
	// {
	// 	$year = $this->interpolateYear($year);
	// 	$totalExpenditure = $totalInvoice = $totalPaidInvoice = 0;


	// 	$totalBudgets = Project::select(DB::raw('SUM(CAST("rencana_biaya" AS DOUBLE PRECISION))'))
	// 		->where('mulai_proyek', 'like', $year)
	// 		/* ->orWhere('akhir_proyek', 'like', $year) */
	// 		->pluck('sum')
	// 		->first();

	// 	$projects = Project::where('mulai_proyek', 'like', $year)
	// 		/* ->orWhere('akhir_proyek', 'like', $year) */
	// 		->get();
	// 	foreach ($projects as $project) {
	// 		$project->expenses = 0;

	// 		$resp = null;
	// 		if ($project->kode_sortname != "") {
	// 			$resp = $this->getInvoiceIntegration($project->kode_sortname);
	// 			/* $resp = $project->kode_sortname; */
	// 			$cost = $resp->data->total_cost ?? 0;
	// 			$cost = substr($cost, 0, strpos($cost, "."));
	// 			$totalExpenditure += (int) $cost;
	// 			$totalInvoice += $resp->data->total_invoice_amount ?? 0;
	// 			$totalPaidInvoice += $resp->data->total_invoice_paid_amount ?? 0;
	// 		}

	// 	}

	// 	return response()->json([
	// 		'data' => [
	// 			'total_budget' => (int) $totalBudgets ?? 0,
	// 			'total_expenditure' => $totalExpenditure,
	// 			'total_invoice' => $totalInvoice,
	// 			'total_paid_invoice' => $totalPaidInvoice,
	// 		]
	// 	], 200);
	// }

	public function getCompanyCashFlow($year = '%', $company_id, $all_project, $hierarchy)
	{
		$year = $this->interpolateYear($year);
		$totalExpenditure = $totalInvoice = $totalPaidInvoice = 0;

		$totalBudgets = null;
		if ($all_project) {
			$totalBudgets = Project::where('mulai_proyek', 'like', $year)
				->where('company_id', $company_id)
				->sum(DB::raw('CAST("rencana_biaya" AS DOUBLE PRECISION)'));
		} else {
			$totalBudgets = Project::where('mulai_proyek', 'like', $year)
				->where('created_by_id', $hierarchy)
				->sum(DB::raw('CAST("rencana_biaya" AS DOUBLE PRECISION)'));
		}

		$projects = null;
		if ($all_project) {
			$projects = Project::where('mulai_proyek', 'like', $year)
				->where('company_id', $company_id)
				->get();
		} else {
			$projects = Project::where('mulai_proyek', 'like', $year)
				->where('created_by_id', $hierarchy)
				->get();
		}

		foreach ($projects as $project) {
			$project->expenses = 0;
			$resp = null;
			if ($project->kode_sortname != "") {

				$resp = $this->getInvoiceIntegration($project->kode_sortname);
				$cost = $resp->data->total_cost ?? 0;
				$cost = substr($cost, 0, strpos($cost, "."));
				$cost = 0;
				$totalExpenditure = 0;
				$totalInvoice = 0;
				$totalPaidInvoice = 0;

				// $totalExpenditure += (int) $cost;
				// $totalInvoice += $resp->data->total_invoice_amount ?? 0;
				// $totalPaidInvoice += $resp->data->total_invoice_paid_amount ?? 0;
			}
		}

		return response()->json([
			'data' => [
				'total_budget' => (int) $totalBudgets ?? 0,
				'total_expenditure' => $totalExpenditure,
				'total_invoice' => $totalInvoice,
				'total_paid_invoice' => $totalPaidInvoice,
			]
		], 200);
	}


	public function getInvoiceOutstanding($year = '%')
	{
		$year = $this->interpolateYear($year);
		$projects = Project::where('mulai_proyek', 'like', $year)
			/* ->orWhere('akhir_proyek', 'like', $year) */
			->get();
		$return = [];
		foreach ($projects as $project) {
			$resp = null;
			if ($project->kode_sortname != "") {
				$resp = $this->getInvoiceIntegration($project->kode_sortname);
				array_push($return, [
					'project' => $project->nama,
					'project_code' => $project->kode_sortname,
					'invoiced' => $resp->data->total_invoice_amount ?? 0,
					'paid' => $resp->data->total_invoice_paid_amount ?? 0,
					'response' => $resp,
				]);
			}
		}

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

	public function getTotalProjectPerScheduleHealth($year = '%', $company_id, $all_project, $hierarchy)
	{
		$year = $this->interpolateYear($year);

		$return = [
			'behind-schedule' => 0,
			'warning' => 0,
			'on-schedule' => 0,
		];

		$projects = null;
		if ($all_project) {
			$projects = Project::where('mulai_proyek', 'like', $year)
				->where('company_id', $company_id)
				->get();
		} else {
			$projects = Project::where('mulai_proyek', 'like', $year)
				->where('created_by_id', $hierarchy)
				->get();
		}

		foreach ($projects as $index => $project) {
			$project->scurve = MasterFunctionsHelper::getSCurve($project->id);
			$selisihProgress = 0;
			$planningProgress = 0;
			$actualProgress = 0;

			if ($project->scurve && $project->scurve[0]) {
				$planningArray = $project->scurve[0]['data']['percentagePlan'];
				$actualArray = $project->scurve[0]['data']['percentageReal'];
				$planningProgress = !empty($planningArray) ? $planningArray[count($planningArray) - 1] : 0;
				$actualProgress = !empty($actualArray) ? $actualArray[count($actualArray) - 1] : 0;
			}
			$selisihProgress = $planningProgress - $actualProgress;
			try {
				if ($selisihProgress > 0 && $selisihProgress <= 5) {
					$return['warning'] += 1;
					$projects[$index]->status = 'warning';
				} elseif ($selisihProgress == 0) {
					$return['on-schedule'] += 1;
					$projects[$index]->status = 'on-schedule';
				} else {
					$return['behind-schedule'] += 1;
					$projects[$index]->status = 'behind-schedule';
				}
			} catch (\Error $e) {
				return response()->json(['msg' => $e->getMessage(), 'data' => $project], 200);
			}
		}

		return response()->json(['data' => $return, 'q' => $projects], 200);
	}

	public function getTotalProjectScheduleHealthPerDivision($year = '%')
	{
		$year = $this->interpolateYear($year);

		$divisions = Divisi::whereNull('parent')->get();
		foreach ($divisions as $index => $division) {

			$scheduleData = new Collection();
			$behindSchedule = $warning = $onSchedule = 0;

			$projects = Project::where('mulai_proyek', 'like', $year)->where('divisi_id', $division->id)->get();
			foreach ($projects as $project) {
				$project->scurve = MasterFunctionsHelper::getSCurve($project->id);
				$selisihProgress = 0;
				$planningProgress = 0;
				$actualProgress = 0;

				if ($project->scurve && $project->scurve[0]) {
					$planningArray = $project->scurve[0]['data']['percentagePlan'];
					$actualArray = $project->scurve[0]['data']['percentageReal'];
					$planningProgress = !empty($planningArray) ? $planningArray[count($planningArray) - 1] : 0;
					$actualProgress = !empty($actualArray) ? $actualArray[count($actualArray) - 1] : 0;
				}
				$selisihProgress = $planningProgress - $actualProgress;
				if ($selisihProgress > 0 && $selisihProgress <= 5) {
					$warning++;
				} elseif ($selisihProgress == 0) {
					$onSchedule++;
				} else {
					$behindSchedule++;
				}
			}

			$scheduleData->prepend($behindSchedule, 'behindSchedule');
			$scheduleData->prepend($warning, 'warning');
			$scheduleData->prepend($onSchedule, 'onSchedule');
			$divisions[$index]->scheduleData = $scheduleData;
		}
		return response()->json([
			'data' => [
				$divisions
			]
		], 200);
	}

	public function getTotalProjectPerBudgetHealth($year = '%')
	{
		$year = $this->interpolateYear($year);
		return response()->json([
			'data' => [
				'overrun' => Project::where('mulai_proyek', 'like', $year)->where('budget_health', 'overrun')->count(),
				'warning' => Project::where('mulai_proyek', 'like', $year)->where('budget_health', 'warning')->count(),
				'on-budget' => Project::where('mulai_proyek', 'like', $year)->where('budget_health', 'on-budget')->count(),
			]
		], 200);
	}

	private function countTotalProjectByBudgetHealthInDivision($divisi, $year, $health)
	{
		return Project::where('divisi_id', $divisi)
			->where('mulai_proyek', 'like', $year)
			/* ->orWhere('akhir_proyek', 'like', $year) */
			->where('budget_health', $health)
			->count();
	}


	public function getTotalProjectBudgetHealthPerDivision($year = '%')
	{
		$year = $this->interpolateYear($year);
		$divisions = Divisi::select('id', 'name')
			->with('children')
			->whereNull('parent')
			->get();
		// to do : count in more than 1 level child
		foreach ($divisions as $division) {
			$budgetData = new Collection();
			$budgetData->prepend($this->countTotalProjectByBudgetHealthInDivision($division->id, $year, 'overrun'), 'overrun');
			$budgetData->prepend($this->countTotalProjectByBudgetHealthInDivision($division->id, $year, 'warning'), 'warning');
			$budgetData->prepend($this->countTotalProjectByBudgetHealthInDivision($division->id, $year, 'on-budget'), 'on-budget');
			foreach ($division->children as $d) {
				$budgetData['overrun'] += $this->countTotalProjectByBudgetHealthInDivision($d->id, $year, 'overrun');
				$budgetData['warning'] += $this->countTotalProjectByBudgetHealthInDivision($d->id, $year, 'warning');
				$budgetData['on-budget'] += $this->countTotalProjectByBudgetHealthInDivision($d->id, $year, 'on-budget');
			}
			unset($division->children);
			$division->budgetData = $budgetData;
		}
		foreach ($divisions as $division) {
		}
		return response()->json([
			'data' => [
				$divisions
			]
		], 200);
	}

	public function getTotalProjectPerPhase($year = '%', $company_id, $all_project, $hierarchy)
	{
		$year = $this->interpolateYear($year);
		$projectPhases = ProjectPhase::orderBy('order')->get();
		foreach ($projectPhases as $phase) {

			if ($all_project) {
				$phase->totalProject = Project::where('phase_id', $phase->id)
					->where('mulai_proyek', 'like', $year)
					->where('company_id', $company_id)
					->count();
			} else {
				$phase->totalProject = Project::where('phase_id', $phase->id)
					->where('mulai_proyek', 'like', $year)
					->where('created_by_id', $hierarchy)
					->count();
			}
		}
		return response()->json([
			'data' => [
				$projectPhases
			]
		], 200);
	}

	private function countTotalProjectInDivision($id, $year)
	{
		return Project::where('divisi_id', $id)
			->where('mulai_proyek', 'like', $year)
			->count();
	}

	public function getTotalProjectPerDivision($year = '%')
	{
		$year = $this->interpolateYear($year);

		$divisions = Divisi::select('id', 'name', 'parent', 'color')
			->with('children')
			->whereNull('parent')
			->get();

		// to do : count in more than 1 level child
		foreach ($divisions as $v) {
			$v->total = $this->countTotalProjectInDivision($v->id, $year);
			foreach ($v->children as $d) {
				$v->total += $this->countTotalProjectInDivision($d->id, $year);
			}
			unset($v->children);
		}

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

	private function countTotalProjectValueInDivision($id, $year)
	{
		return Project::select(DB::raw('SUM(CAST("rencana_biaya" AS DOUBLE PRECISION))'))
			->where('mulai_proyek', 'like', $year)
			/* ->orWhere('akhir_proyek', 'like', $year) */
			->where('divisi_id', $id)
			->pluck('sum')
			->first();
	}

	public function getTotalProjectValuePerDivision($year = '%')
	{
		$year = $this->interpolateYear($year);

		$divisions = Divisi::select('id', 'name', 'color')
			->with('children')
			->whereNull('parent')
			->get();

		// to do : count in more than 1 level child
		foreach ($divisions as $v) {
			$v->total = $this->countTotalProjectValueInDivision($v->id, $year);
			foreach ($v->children as $d) {
				$v->total += $this->countTotalProjectValueInDivision($d->id, $year);
			}
			unset($v->children);
		}

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


	public function getDetailExpenditure($year = '%')
	{
		$year = $this->interpolateYear($year);
		$projects = Project::where('mulai_proyek', 'like', $year)
			/* ->orWhere('akhir_proyek', 'like', $year) */
			->orderBy('id', 'desc')
			->get();
		foreach ($projects as $project) {
			$lastGantt = MasterFunctionsHelper::getLatestGantt($project->id);

			if ($project->kode_sortname != "") {
				$resp = $this->getInvoiceIntegration($project->kode_sortname);
				$project->invoice = [
					'invoiced' => $resp->data->total_invoice_amount ?? 0,
					'paid' => $resp->data->total_invoice_paid_amount ?? 0,
				];
			}

			$project->pm = User::find($project->pm_id);
			/* $project->header = Activity::where('proyek_id', $project->id)->where('version_gantt_id', $lastGantt['last_gantt_id'])->whereNull('parent_id')->first(); */
			if (!isset($lastGantt['last_gantt_id'])) {
				$project->manPowers = 0;
			} else {
				$project->manPowers = UserToVersionGantt::where('version_gantt_id', $lastGantt['last_gantt_id'])->count();
				$project->scurve = MasterFunctionsHelper::getSCurve($project->id);
			}
			$project->lastGanttId = MasterFunctionsHelper::getLatestGantt($project->id);
		}

		return response()->json([
			'data' => $projects,
			'total_manpowers' => User::count()
		], 200);
	}
}