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); } }