ordo
/
surveyor_indonesia_backend
2
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
Browse Source

Merge pull request 'update register & add DB transaction' (#66) from dev-wahyun into staging 

Reviewed-on: ibnu/generic-ospro-backend#66
pull/1/head
farhantock 10 months ago
parent
b06e33b9cc f0e79dbaf4
commit
21d82a6cfb
4 changed files with 683 additions and 579 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 39
      app/Http/Controllers/CompanyController.php
  2. 11
      app/Http/Controllers/Controller.php
  3. 279
      app/Http/Controllers/ProjectController.php
  4. 161
      app/Http/Controllers/UserRegisterController.php

39
app/Http/Controllers/CompanyController.php
Unescape View File

@ -2,9 +2,9 @@
namespace App\Http\Controllers;
use App\Models\Company;
use App\Models\MenuCompany;
use App\Models\{User, RoleMenu, Role, ProductTransaction, MenuCompany, Company};
use Illuminate\Http\Request;
use Illuminate\Support\Facades\DB;
class CompanyController extends Controller
{
@ -66,8 +66,6 @@ class CompanyController extends Controller
return response()->json(['status' => 'failed', 'message' => 'data Company not found!', 'code' => 400], 400);
die();
}
if ($result) {
return response()->json(['status' => 'success', 'message' => 'data Company successfully updated!', 'code' => 200], 200);
} else {
@ -77,24 +75,37 @@ class CompanyController extends Controller
public function delete($id)
{
$data = Company::find($id);
DB::beginTransaction();
$data = Company::find((int)$id);
if ($data) {
MenuCompany::where('company_id',$id)->delete();
$delete = $data->delete();
$this->deleteRelative((int)$data['id']);
if ($data->delete()) {
DB::commit();
return response()->json(['status' => 'success', 'message' => 'Data Company successfully deleted!', 'code' => 200], 200);
} else {
return response()->json(['status' => 'failed', 'message' => 'data Company not found!', 'code' => 400], 400);
DB::rollBack();
return response()->json(['status' => 'failed', 'message' => 'Data Company failed deleted!', 'code' => 400], 400);
}
} else {
DB::rollBack();
return response()->json(['status' => 'failed', 'message' => 'Data Company not found!', 'code' => 400], 400);
die();
}
}
if ($delete) {
return response()->json(['status' => 'success', 'message' => 'data Company successfully deleted!', 'code' => 200], 200);
} else {
return response()->json(['status' => 'failed', 'message' => 'data Company failed deleted!', 'code' => 400], 400);
private function deleteRelative($company_id)
{
MenuCompany::where('company_id', $company_id)->delete();
User::where('company_id', $company_id)->delete();
$role = Role::where('company_id', $company_id)->first();
if ($role) {
RoleMenu::where('role_id', $role->id)->delete();
$role->delete();
}
ProductTransaction::where('company_id', $company_id)->delete();
}
public function search(Request $request)
{
$payload = $request->all();

11
app/Http/Controllers/Controller.php
Unescape View File

@ -45,10 +45,13 @@ class Controller extends BaseController
protected function setCustomeDirectoryUpload($company_name)
{
$pathImage = 'assets/' . $company_name . '/image/';
$pathDocument = 'assets/' . $company_name . '/file/project/';
$pathTmpImport = 'assets/' . $company_name . '/file/tmpimport/';
$pathActivityDocument = 'assets/' . $company_name . '/file/activity/';
$current_date = date('Y-m-d');
[$year, $month, $day] = explode('-', $current_date);
$pathImage = 'assets/' . $company_name . ' ' . $year . '-' . $month . '-' . $day . '/image/';
$pathDocument = 'assets/' . $company_name . ' ' . $year . '-' . $month . '-' . $day . '/file/project/';
$pathTmpImport = 'assets/' . $company_name . ' ' . $year . '-' . $month . '-' . $day . '/file/tmpimport/';
$pathActivityDocument = 'assets/' . $company_name . ' ' . $year . '-' . $month . '-' . $day . '/file/activity/';
return [
'pathImage' => $pathImage,

279
app/Http/Controllers/ProjectController.php
Unescape View File

@ -3,46 +3,16 @@
namespace App\Http\Controllers;
use DateTime;
use App\Models\Link;
use App\Models\User;
use App\Models\Image;
use App\Models\Company;
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 App\Models\ProductTransaction;
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 App\Models\{ReportActivityMaterial,ProjectToChecklistK3,FolderDocumentProyek,ProjectParticipants,ProductTransaction,ProjectChecklists,
ProjectMileStone,RequestMaterial,ProjectApproval,CommentActivity,ActivityDokumen,UserToActivity,ShowHideColumn,ReportActivity,ProjectCharter,DokumenProject,
AssignMaterial,ProjectIssues,HierarchyFtth,VersionGantt,UserToProyek,ProjectRisks,ProjectPhase,ProjectType,OfficeHours,AssignTools,ReportK3,Activity,Project,
Holiday,Company,Image,User,Link
};
use Illuminate\Database\Query\Builder;
use Illuminate\Support\Facades\Artisan;
use Illuminate\Support\Facades\{Artisan,DB};
use App\Helpers\MasterFunctionsHelper;
const API_GEOLOCATION = "https://nominatim.oslogdev.com/search/ADDR?format=json&addressdetails=1&limit=1";
@ -60,16 +30,15 @@ class ProjectController extends Controller
'type_proyek_id' => 'required',
'company_id' => 'required'
]);
DB::beginTransaction();
try {
$data = $request->all();
$data['created_by'] = $this->currentName;
$data['created_by_id'] = $this->currentId;
if (empty($data['phase_id'])) {
$data['phase_id'] = 1;
}
$transaction = ProductTransaction::query()
->where('company_id', $request->company_id);
$cloneQueryTransaction = clone $transaction;
@ -93,23 +62,27 @@ class ProjectController extends Controller
if($countCreate) {
$result = Project::create($data);
if (!$result) {
return response()->json(['status' => 'failed', 'message' => 'Failed to add data!', 'code' => 500], 500);
} else {
$this->createOfficeHours($result['id']);
$dataResultInsert = Project::where([['nama', $data['nama']],['mulai_proyek', $data['mulai_proyek']]])->first();
DB::commit();
return response()->json(['status' => 'success', 'message' => 'Data added!', 'data_result' => $dataResultInsert, 'code' => 200], 200);
}
} else {
return response()->json(['status' => 'failed', 'message' => 'Limited to create project!', 'code' => 500], 500);
}
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);
} catch (\Throwable $th) {
DB::rollBack();
}
}
public function edit($id)
{
if (empty($id) || !is_int((int)$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')
@ -157,28 +130,30 @@ class ProjectController extends Controller
->join('m_divisi as md', 'md.id', '=', 'm_proyek.divisi_id')
->where('m_proyek.id', $id)
->first();
if (!$result)
if (!$result) {
return response()->json(['status' => 'failed', 'message' => 'Data not found!', 'code' => 404], 404);
} else {
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);
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);
if ($data) {
if ($data->update($request->all())) {
return response()->json(['status' => 'success', 'message' => 'Data updated!', 'code' => 200], 200);
} else {
return response()->json(['status' => 'failed', 'message' => 'Failed to update!', 'code' => 500], 500);
}
} else {
return response()->json(['status' => 'failed', 'message' => 'Data not found!', 'code' => 404], 404);
}
}
private function createOfficeHours($proyek_id)
@ -209,21 +184,26 @@ class ProjectController extends Controller
public function delete($id, $company_id)
{
DB::beginTransaction();
$data = Project::find($id);
if (!$data)
return response()->json(['status' => 'failed', 'message' => 'Data not found!', 'code' => 404], 404);
if ($data) {
$this->deleteRelative($id, $company_id);
if (!$data->delete())
return response()->json(['status' => 'failed', 'message' => 'Delete failed!', 'code' => 500], 500);
if ($data->delete()) {
DB::commit();
return response()->json(['status' => 'success', 'message' => 'Data deleted!', 'code' => 200], 200);
} else {
DB::rollBack();
return response()->json(['status' => 'failed', 'message' => 'Delete failed!', 'code' => 500], 500);
}
} else {
DB::rollBack();
return response()->json(['status' => 'failed', 'message' => 'Data not found!', 'code' => 404], 404);
}
}
private function deleteRelative($project_id, $company_id)
{
DB::transaction(function() use($project_id, $company_id) {
UserToProyek::where('proyek_id', $project_id)->delete();
UserToActivity::where('proyek_id', $project_id)->delete();
AssignMaterial::where('proyek_id', $project_id)->delete();
@ -242,10 +222,12 @@ class ProjectController extends Controller
RequestMaterial::where('proyek_id', $project_id)->delete();
$this->deleteVersionGantt($project_id, $company_id);
$this->deleteDokumenProject($project_id, $company_id);
},5);
}
private function deleteVersionGantt($project_id, $company_id)
{
DB::transaction(function() use($project_id, $company_id) {
$dataVg = VersionGantt::where("proyek_id", $project_id)->pluck("id");
$vhIds = $dataVg->all();
$activity = Activity::whereIn("version_gantt_id", $vhIds)->pluck('id');
@ -278,11 +260,13 @@ class ProjectController extends Controller
ShowHideColumn::whereIn("version_gantt_id", $vhIds)->delete();
Activity::whereIn("version_gantt_id", $vhIds)->delete();
ReportActivity::whereIn("activity_id", $activityIds)->delete();
},5);
}
private function deleteDokumenProject($project_id, $company_id)
{
$dataDokumen = DokumenProject::where("type_dokumen", "project-document-out-folder")->where('ref_id', $project_id)->get();
DB::transaction(function() use($project_id, $company_id){
$dataDokumen = DokumenProject::where([['type_dokumen', 'project-document-out-folder'],['ref_id', $project_id]])->get();
$company = Company::find($company_id);
if($company) {
$destinationPath = $this->setCustomeDirectoryUpload($company['company_name']);
@ -292,8 +276,7 @@ class ProjectController extends Controller
}
}
}
DokumenProject::where("type_dokumen", "project-document-out-folder")->where('ref_id', $project_id)->delete();
DokumenProject::where([['type_dokumen', 'project-document-out-folder'],['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();
@ -302,8 +285,8 @@ class ProjectController extends Controller
unlink($destinationPath['pathDocument'] . $dokumen->file);
}
}
DokumenProject::where("type_dokumen", "project-document-in-folder")->whereIn('ref_id', $ref_ids)->delete();
},5);
}
public function search(Request $request)
@ -313,7 +296,6 @@ class ProjectController extends Controller
$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();
@ -322,6 +304,8 @@ class ProjectController extends Controller
public function list()
{
DB::beginTransaction();
try {
$data = Project::select(
'id',
'kode_sortname',
@ -359,13 +343,12 @@ class ProjectController extends Controller
'created_by',
'updated_at',
'updated_by'
)->orderBy('id', 'desc')
// ->where("created_by",$this->currentName)
)->orderByDesc('id')
->get();
$countData = $data->count();
if (!$data)
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');
@ -373,25 +356,17 @@ class ProjectController extends Controller
$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()]);
}
DB::commit();
return response()->json(
[
'status' => 'success',
@ -410,6 +385,9 @@ class ProjectController extends Controller
],
200
);
} catch (\Throwable $th) {
DB::rollBack();
}
}
public function getListProjectTask($id)
@ -420,10 +398,12 @@ class ProjectController extends Controller
->groupBy("m_proyek.proyek_id")
->get();
if (!$data)
if ($data) {
return response()->json(['status' => 'success', 'code' => 200, 'data' => $data], 200);
} else {
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)
@ -469,15 +449,17 @@ class ProjectController extends Controller
public static function setSyncDate($activity_id, $activity, $report)
{
DB::beginTransaction();
try {
$status = AssignMaterial::where('activity_id', $activity_id)->first();
if (!isset($status)) {
$reports = array(
DB::commit();
return [
'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';
@ -491,17 +473,22 @@ class ProjectController extends Controller
$minDate = date_create($material->start_activity);
$maxDate = date_create($material->finish_activity);
}
$reports = array(
DB::commit();
return [
'activity_id' => $activity_id,
'min_date' => $minDate,
'max_date' => $maxDate,
'status' => $status->status_activity
);
return $reports;
];
} catch (\Throwable $th) {
DB::rollBack();
}
}
public function synchronizeReport($gantt_id)
{
DB::beginTransaction();
try {
$activities = Activity::where("version_gantt_id", $gantt_id)->get();
$reports = [];
@ -511,12 +498,12 @@ class ProjectController extends Controller
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);
$reports[] = self::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);
$reports[] = self::setSyncDate($activity_id, $activity, $firstReport);
}
$successor = Link::where('t_activity_id', $activity->id)->first();
if ($successor) {
@ -544,8 +531,11 @@ class ProjectController extends Controller
$activity->actual_start = $reports[$i]['min_date'];
$activity->save();
}
DB::commit();
return response()->json(['status' => 'success', 'message' => 'Synchronize to report success!', 'code' => 200], 200);
} catch (\Throwable $th) {
DB::rollBack();
}
}
public function setBaseline($gantt_id)
@ -566,10 +556,7 @@ class ProjectController extends Controller
public function setBaselineActivity($activity_id, $gantt_id)
{
$activity = Activity::where([
["version_gantt_id", $gantt_id],
['id',$activity_id]
])->first();
$activity = Activity::where([["version_gantt_id", $gantt_id],['id',$activity_id]])->first();
$activity->update([
"planned_start" => $activity->start_date,
"planned_end" => $activity->end_date,
@ -581,30 +568,32 @@ class ProjectController extends Controller
public function getInvoiceIntegration(Request $request)
{
DB::beginTransaction();
try {
$ganttCount = VersionGantt::where('proyek_id', $request->id)->count();
$search = urlencode($request->search);
if (empty($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;
}
DB::commit();
return response()->json(['status' => 'success', 'data' => $response, 'code' => 200], 200);
} catch (\Throwable $th) {
DB::rollBack();
}
}
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')
->from('assign_hr_to_proyek AS utp')
->where([['is_customer', true],['user_id', $id]])
->leftJoin('m_users', 'utp.user_id', '=', 'm_users.id')
->leftJoin('m_proyek', 'utp.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();
@ -612,15 +601,19 @@ class ProjectController extends Controller
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);
DB::beginTransaction();
try {
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)
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'];
@ -641,7 +634,7 @@ class ProjectController extends Controller
} else {
// $actualEndExist = Activity::where('version_gantt_id', $ganttId)->exists();
$maxEndDate = Activity::where('version_gantt_id', $ganttId)->select('end_date')
->orderBy('end_date', 'desc')
->orderByDesc('end_date')
->first();
$query = Activity::where('version_gantt_id', $ganttId);
}
@ -650,7 +643,7 @@ class ProjectController extends Controller
$actualStartExist = Activity::where('version_gantt_id', $ganttId)->whereNotNull('actual_start')->exists();
// $actualEndExist = Activity::where('version_gantt_id', $ganttId)->exists();
$maxEndDate = Activity::where('version_gantt_id', $ganttId)->select('end_date')
->orderBy('end_date', 'desc')
->orderByDesc('end_date')
->first();
$query = Activity::where('version_gantt_id', $ganttId);
}
@ -680,19 +673,27 @@ class ProjectController extends Controller
$result->header->planned_start = $plannedStart;
$result->header->planned_end = $plannedEnd;
}
DB::commit();
return response()->json(['status' => 'success', 'code' => 200, 'data' => $result, 'gantt' => $ganttId], 200);
} catch (\Throwable $th) {
DB::rollBack();
}
}
public function getOverdueActivities(Request $request)
{
DB::beginTransaction();
try {
$payload = $request->all();
if (empty($payload['id']) || !is_int((int)$payload['id']))
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)
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')
@ -711,18 +712,25 @@ class ProjectController extends Controller
}
}
$result->overdueActivities = $overdueActivities;
DB::commit();
return response()->json(['status' => 'success', 'code' => 200, 'data' => $result], 200);
} catch (\Throwable $th) {
DB::rollBack();
}
}
public function getReportDistribution(Request $request)
{
DB::beginTransaction();
try {
$payload = $request->all();
if (empty($payload['project_id']) || !is_int((int)$payload['project_id']))
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')
$reports = AssignMaterial::query()
->from('assign_material_to_activity AS ama')
->select(
'u.name',
'a.name as activity_name',
@ -742,8 +750,11 @@ class ProjectController extends Controller
->where('ama.proyek_id', '=', $payload['project_id'])
->whereNotNull('ram.lat')
->whereBetween('ram.report_date', [$payload['start_date'], $payload['end_date']]);
DB::commit();
return response()->json(['status' => 'success', 'code' => 200, 'data' => $reports], 200);
} catch (\Throwable $th) {
DB::rollBack();
}
}
public function getManpower($proyek_id)
@ -763,7 +774,10 @@ class ProjectController extends Controller
public function dashboard($id)
{
$data = DB::table('m_proyek as mp')
DB::beginTransaction();
try {
$data = Project::query()
->from('m_proyek AS mp')
->select(
'mp.kode_sortname',
'mp.nama as name_project',
@ -779,16 +793,18 @@ class ProjectController extends Controller
->where('mp.id', $id)
->first();
if (!$data)
return response()->json(['status' => 'failed', 'message' => 'Data tidak ditemukan!', 'code' => 404], 404);
if (!$data) {
return response()->json(['status' => 'failed', 'message' => 'Data not found!', '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();
$rootActivity = Activity::whereNull('parent_id')->where('proyek_id', $id)->orderByDesc('version_gantt_id')->first();
$actualCost = @$rootActivity->biaya_actual ?? 0;
$progress = @$rootActivity->persentase_progress ?? 0;
$commentActivity = DB::table('m_comment_activity as mca')
$commentActivity = CommentActivity::query()
->from('m_comment_activity AS mca')
->select(
'mca.activity_id',
'mca.comment as comment',
@ -806,8 +822,11 @@ class ProjectController extends Controller
$data->progress = $progress;
$data->comment = $commentActivity;
$data->man_power = $manpowers;
DB::commit();
return response()->json(['status' => 'success', 'code' => 200, 'data' => $data], 200);
} catch (\Throwable $th) {
DB::rollBack();
}
}
private function httpReq($search)

161
app/Http/Controllers/UserRegisterController.php
Unescape View File

@ -5,38 +5,49 @@ namespace App\Http\Controllers;
use Carbon\Carbon;
use Illuminate\Support\Str;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\{DB,Validator};
use App\Models\{Company, HumanResource, Menu, ProductTransaction, RefferalCode, Role, RoleMenu, MenuCompany};
use Illuminate\Support\Facades\{DB,Log};
use App\Models\{User, Company, HumanResource, Menu, ProductTransaction, RefferalCode, Role, RoleMenu, MenuCompany};
const URL_EMAIL = 'https://notifapp.odm-iu.com/service-mail/notif_mail.php';
class UserRegisterController extends Controller
{
public function add(Request $request)
{
DB::transaction(function () use ($request) {
$validator = Validator::make($request->all(), [
'refferal' => 'unique:refferal_code,code',
DB::beginTransaction();
$this->validate($request, [
'cluster' => 'required|string',
'address' => 'required|string',
'email' => 'required|unique:' . ($request->type_account === 'Company' ? 'm_company' : 'm_users') . ',email',
'type_paket' => 'required|in:Basic, Free',
'email' => 'required|string',
'type_paket' => ($request->type_account === 'Personal' ? 'required' : 'nullable') . '|in:Basic,Free',
'phone_no' => 'required',
'type_account' => 'string|in:Personal, Company',
'type_account' => 'string|in:Personal,Company',
'company_name' => 'required|string',
'username' => 'string|required|unique:' . ($request->type_account === 'Personal' ? 'm_users' : '') . ',username'
'username' => 'required|string'
]);
if ($validator->fails()) {
return response()->json(['status' => 'failed', 'message' => $validator->errors()->first(), 'code' => 400], 400);
}
$data = $validator->validated();
try {
$data = $request->all();
$company_name = $data['company_name'];
$type_account = $data['type_account'];
$refferal = $data['refferal'];
$refferal = $request->refferal ? $data['refferal'] : null;
$cluster = $data['cluster'];
$address = $data['address'];
$phone_no = $data['phone_no'];
$email = $data['email'];
$username = $data['username'];
$type_paket = $data['type_paket'];
$company_address = $request->type_account === 'Company' ? $data['companyAddress'] : '';
$full_name = $request->type_account === 'Personal' ? $data['full_name'] : '';
// check email & username already exist
$emailExists = Company::where('email', $email)->exists() || User::where('email', $email)->exists();
if ($emailExists) {
return response()->json(['status' => 'failed', 'message' => 'Email already exists, please check again!', 'code' => 500], 500);
}
$usernameExists = User::where('username', $username)->exists();
if ($usernameExists) {
return response()->json(['status' => 'failed', 'message' => 'Username already exists, please check again!', 'code' => 500], 500);
}
// Get last registration number
$getCompany = $this->getCompany();
@ -50,7 +61,9 @@ class UserRegisterController extends Controller
'address' => $address,
'type_account' => $type_account,
'username' => $username,
'type_paket' => $type_paket
'type_paket' => $type_paket,
'companyAddress' => $company_address,
'full_name' => $full_name
);
if(empty($refferal)) {
@ -58,47 +71,46 @@ class UserRegisterController extends Controller
} else {
$getRefferal = $this->getRefferalCode($refferal);
if(empty($getRefferal)) {
return response()->json(['status' => 'failed', 'message' => 'Refferal Code Not Found!', 'code' => 404], 404);
return response()->json(['status' => 'failed', 'message' => 'Refferal code not found!', 'code' => 404], 404);
}
$addCompany = $this->addCompany($formDataCompany, $getRefferal['id']);
$addCompany = $this->addCompany($formDataCompany, (int)$getRefferal['id']);
}
if(empty($addCompany)) {
return;
die();
}
$addRole = $this->addRole((int)$addCompany['id']);
if(empty($addRole)) {
return;
die();
}
$addHR = $this->addHR((int)$addCompany['id'], (int)$addRole['id'], $formDataCompany);
if(empty($addHR)) {
return;
die();
}
$getMenu = $this->getMenu();
if(empty($getMenu)) {
return;
die();
}
$this->addTransaction((int)$addCompany['id'], $formDataCompany);
$addMenuCompany = $this->addMenuCompany($getMenu, (int)$addCompany['id']);
if(empty($addMenuCompany)) {
return;
die();
}
$addMenuRole = $this->addMenuRole($getMenu, (int)$addRole['id']);
if($addMenuRole) {
return response()->json(['status' => 'success', 'message' => 'Register is successfully!', 'code' => 200], 200);
if(empty($addMenuRole)) {
return;
}
DB::commit();
return response()->json(['status' => 'success', 'message' => 'Register is successful, please check your email!', 'generateRandom' => $addHR['generateRandom'], 'code' => 200], 200);
} catch (\Throwable $th) {
DB::rollBack();
Log::channel('daily')->error($th->getMessage());
return response()->json(['status' => 'failed', 'message' => 'Failed to register, please check again!', 'code' => 500], 500);
}
},3);
}
protected function getRefferalCode($refferal)
@ -119,11 +131,11 @@ class UserRegisterController extends Controller
'date_register' => Carbon::now(),
'template_id' => 1,
'email' => $formData['email'],
'address' => $formData['address'],
'address' => $formData['type_account'] === 'Company' ? $formData['companyAddress'] : $formData['address'],
'phone_no' => $formData['phone_no'],
'type_account' => $formData['type_account'],
'is_active' => true,
'discount_id' => $id_refferal === null ? null : (int)$id_refferal
'discount_id' => $id_refferal === null ? null : $id_refferal
);
$result = Company::create($formData);
return $result;
@ -142,25 +154,27 @@ class UserRegisterController extends Controller
protected function addHR($id_company, $id_role, $data)
{
$generatePassword = Str::password(10);
$generateRandom = Str::random(8);
$formData = array(
'name'=> $data['company_name'],
'name'=> $data['type_account'] === 'Company' ? $data['username'] : $data['full_name'],
'phone_number'=> $data['phone_no'],
'email'=> $data['email'],
'username' => $data['username'],
'password'=> $generatePassword,
'role_id'=> (int)$id_role,
'ktp_number'=> $data['type_account'] === 'Company' ? 'CP-' : 'PR-' . Str::random(5),
'employee_type'=>'employee',
'password'=> md5($generateRandom),
'role_id'=> $id_role,
'ktp_number'=> $data['type_account'] === 'Company' ? 'CP-'. $generateRandom : 'PR-' . $generateRandom,
'employee_type'=> 'employee',
'address' => $data['address'],
'status_resource'=> 'active',
'company_id'=> (int)$id_company
'company_id'=> $id_company
);
$result = HumanResource::create($formData);
if(!empty($result)) {
$this->sendEmail($data['email'], $generateRandom);
}
return [
'result' => $result,
'generatePassword' => $generatePassword
'generateRandom' => $generateRandom
];
}
@ -170,7 +184,7 @@ class UserRegisterController extends Controller
if($data->exists()){
$data->delete();
}
if (is_array($baseDataMenu) && count($baseDataMenu) > 0 && isset($baseDataMenu)) {
if (is_object($baseDataMenu) && count($baseDataMenu) > 0 && isset($baseDataMenu)) {
$countRes = 0;
foreach ($baseDataMenu as $menu) {
$dataInsert = array(
@ -193,16 +207,16 @@ class UserRegisterController extends Controller
if ($countRes > 0) {
return $result;
} else {
return $result;
die();
}
} else {
return false;
die();
}
}
protected function addMenuRole($baseDataMenu, $id_role)
{
if (is_array($baseDataMenu) && count($baseDataMenu) > 0 && isset($baseDataMenu)) {
if (is_object($baseDataMenu) && count($baseDataMenu) > 0 && isset($baseDataMenu)) {
$countRes = 0;
foreach ($baseDataMenu as $menu) {
$dataInsert = array(
@ -219,10 +233,10 @@ class UserRegisterController extends Controller
if ($countRes > 0) {
return $result;
} else {
return $result;
die();
}
} else {
return false;
die();
}
}
@ -263,11 +277,68 @@ class UserRegisterController extends Controller
$lastRegistrationNumber = $company['registration_no'];
$lastNumber = (int)preg_replace('/\D/', '', $lastRegistrationNumber);
$newNumber = $lastNumber + 1;
// $newRegistrationNumber = Str::beforeLast($lastRegistrationNumber, $lastNumber) . $newNumber;
$newRegistrationNumber = 'RG-'. $newNumber;
} else{
return false;
}
return [
'newRegistrationNumber' => $newRegistrationNumber
];
}
public function sendEmail($email, $password)
{
$user = User::select('email', 'name', 'username')->where('email', $email)->first();
if (!$user) {
return response()->json(['status' => 'error', 'message' => 'e-mail not found '], 400);
} else {
$this->reqHttpCurl($email, $password, $user->username, $user->name);
return response()->json(['status' => 'error', 'code'=>400, 'message' => 'e-mail not found '], 400);
}
}
private function reqHttpCurl($email, $password, $username, $name)
{
$postData = [
"to" => $email,
"name" => $name,
"username" => $username,
"password" => $password,
"from" => "app.integrasia@integrasiautama.com",
"alias_from" => "OSPRO",
"subject" => "Registration OSPRO",
"body" => "registration-ospro"
];
$curl = curl_init();
curl_setopt_array($curl, array(
CURLOPT_URL => URL_EMAIL,
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30000,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "POST",
CURLOPT_POSTFIELDS => json_encode($postData),
CURLOPT_HTTPHEADER => array(
// Set here requred headers
"accept: */*",
"accept-language: en-US,en;q=0.8",
"content-type: application/json",
),
));
$response = curl_exec($curl);
$err = curl_error($curl);
curl_close($curl);
if ($err) {
echo "cURL Error #:" . $err;
} else {
print_r(json_decode($response));
}
}
}

Write Preview
Loading…
Cancel
Save