@@ -28,17 +28,17 @@ discard block |
||
| 28 | 28 | $this->academic_period = new Academic_period(); |
| 29 | 29 | $this->institution_classes = new Institution_class(); |
| 30 | 30 | $this->institution_class_subjects = new Institution_class_subject(); |
| 31 | - $this->institution_subjects = new Institution_subject(); |
|
| 32 | - $this->education_grade_subjects = new Education_grades_subject(); |
|
| 31 | + $this->institution_subjects = new Institution_subject(); |
|
| 32 | + $this->education_grade_subjects = new Education_grades_subject(); |
|
| 33 | 33 | $this->output = new \Symfony\Component\Console\Output\ConsoleOutput(); |
| 34 | 34 | } |
| 35 | 35 | |
| 36 | 36 | |
| 37 | - public function array_walk($shift,$count,$params){ |
|
| 38 | - array_walk($shift,array($this,'process'),$params); |
|
| 37 | + public function array_walk($shift, $count, $params) { |
|
| 38 | + array_walk($shift, array($this, 'process'), $params); |
|
| 39 | 39 | } |
| 40 | 40 | |
| 41 | - public function cleanConfig($params){ |
|
| 41 | + public function cleanConfig($params) { |
|
| 42 | 42 | $academicPeriod = $params['academic_period']; |
| 43 | 43 | $this->shifts->where(['academic_period_id' => $academicPeriod->id])->delete(); |
| 44 | 44 | $this->output->writeln('cleaned shifts'); |
@@ -46,32 +46,32 @@ discard block |
||
| 46 | 46 | $this->shifts->where(['cloned' => $academicPeriod->code])->update(['cloned' => $academicPeriod->code - 1]); |
| 47 | 47 | $this->output->writeln('updated shifts'); |
| 48 | 48 | |
| 49 | - $classIds = $this->institution_classes->select('id')->where(['academic_period_id' => $academicPeriod->id])->get()->toArray(); |
|
| 49 | + $classIds = $this->institution_classes->select('id')->where(['academic_period_id' => $academicPeriod->id])->get()->toArray(); |
|
| 50 | 50 | $this->institution_classes->where(['academic_period_id' => $academicPeriod->id])->delete(); |
| 51 | 51 | $this->output->writeln('cleaned classes'); |
| 52 | 52 | |
| 53 | - $this->institution_class_subjects->whereNotIn( 'institution_class_id' , $classIds)->delete(); |
|
| 53 | + $this->institution_class_subjects->whereNotIn('institution_class_id', $classIds)->delete(); |
|
| 54 | 54 | $this->output->writeln('cleaned subjects'); |
| 55 | 55 | |
| 56 | - do{ |
|
| 57 | - $deleted = $this->institution_subjects->where('academic_period_id',$academicPeriod->id)->limit(100000)->delete(); |
|
| 56 | + do { |
|
| 57 | + $deleted = $this->institution_subjects->where('academic_period_id', $academicPeriod->id)->limit(100000)->delete(); |
|
| 58 | 58 | $this->output->writeln('100000 institutions cleaned shifts'); |
| 59 | - }while($deleted > 0); |
|
| 59 | + } while ($deleted > 0); |
|
| 60 | 60 | } |
| 61 | 61 | |
| 62 | - public function process($shift,$count,$params){ |
|
| 63 | - echo('['.getmypid().']This Process executed at'.date("F d, Y h:i:s A")."\n") ; |
|
| 62 | + public function process($shift, $count, $params) { |
|
| 63 | + echo('['.getmypid().']This Process executed at'.date("F d, Y h:i:s A")."\n"); |
|
| 64 | 64 | $year = $params['year']; |
| 65 | 65 | $academicPeriod = $params['academic_period']; |
| 66 | 66 | $previousAcademicPeriod = $params['previous_academic_period']; |
| 67 | - try{ |
|
| 67 | + try { |
|
| 68 | 68 | $shiftId = $this->updateShifts($year, $shift); |
| 69 | 69 | $institutionClasses = $this->institution_classes->getShiftClasses($shift['id']); |
| 70 | - $institutionSubjects = $this->institution_subjects->getInstitutionSubjects($shift['institution_id'],$previousAcademicPeriod->id); |
|
| 71 | - array_walk($institutionSubjects , array($this,'insertInstitutionSubjects'),$academicPeriod); |
|
| 72 | - if (!empty($institutionClasses) && !is_null($shiftId) && !is_null($academicPeriod) ) { |
|
| 70 | + $institutionSubjects = $this->institution_subjects->getInstitutionSubjects($shift['institution_id'], $previousAcademicPeriod->id); |
|
| 71 | + array_walk($institutionSubjects, array($this, 'insertInstitutionSubjects'), $academicPeriod); |
|
| 72 | + if (!empty($institutionClasses) && !is_null($shiftId) && !is_null($academicPeriod)) { |
|
| 73 | 73 | |
| 74 | - $newInstitutionClasses = $this->generateNewClass($institutionClasses,$shiftId,$academicPeriod->id); |
|
| 74 | + $newInstitutionClasses = $this->generateNewClass($institutionClasses, $shiftId, $academicPeriod->id); |
|
| 75 | 75 | |
| 76 | 76 | $params = [ |
| 77 | 77 | 'previous_academic_period_id' => $previousAcademicPeriod->id, |
@@ -79,21 +79,21 @@ discard block |
||
| 79 | 79 | 'shift_id' =>$shiftId |
| 80 | 80 | ]; |
| 81 | 81 | |
| 82 | - try{ |
|
| 83 | - array_walk($newInstitutionClasses,array($this,'insertInstitutionClasses'),$params); |
|
| 82 | + try { |
|
| 83 | + array_walk($newInstitutionClasses, array($this, 'insertInstitutionClasses'), $params); |
|
| 84 | 84 | $newInstitutionClasses = $this->institution_classes->getShiftClasses($shiftId); |
| 85 | 85 | $this->output->writeln('##########################################################################################################################'); |
| 86 | - $this->output->writeln('updating from '. $shiftId); |
|
| 86 | + $this->output->writeln('updating from '.$shiftId); |
|
| 87 | 87 | |
| 88 | - }catch (\Exception $e){ |
|
| 88 | + }catch (\Exception $e) { |
|
| 89 | 89 | dd($e); |
| 90 | - Log::error($e->getMessage(),[$e]); |
|
| 90 | + Log::error($e->getMessage(), [$e]); |
|
| 91 | 91 | } |
| 92 | 92 | } |
| 93 | 93 | // DB::commit(); |
| 94 | - }catch (\Exception $e){ |
|
| 94 | + }catch (\Exception $e) { |
|
| 95 | 95 | // DB::rollBack(); |
| 96 | - Log::error($e->getMessage(),[$e]); |
|
| 96 | + Log::error($e->getMessage(), [$e]); |
|
| 97 | 97 | } |
| 98 | 98 | } |
| 99 | 99 | |
@@ -103,31 +103,31 @@ discard block |
||
| 103 | 103 | * @param $count |
| 104 | 104 | * @param $academicPeriod |
| 105 | 105 | */ |
| 106 | - public function insertInstitutionSubjects($subjects, $count,$academicPeriod){ |
|
| 107 | - try{ |
|
| 106 | + public function insertInstitutionSubjects($subjects, $count, $academicPeriod) { |
|
| 107 | + try { |
|
| 108 | 108 | $subjects['academic_period_id'] = $academicPeriod->id; |
| 109 | 109 | $subjects['created'] = now(); |
| 110 | 110 | unset($subjects['total_male_students']); |
| 111 | 111 | unset($subjects['total_female_students']); |
| 112 | 112 | unset($subjects['id']); |
| 113 | 113 | $this->institution_subjects->create($subjects); |
| 114 | - }catch (\Exception $e){ |
|
| 115 | - Log::error($e->getMessage(),[$e]); |
|
| 114 | + }catch (\Exception $e) { |
|
| 115 | + Log::error($e->getMessage(), [$e]); |
|
| 116 | 116 | } |
| 117 | 117 | } |
| 118 | 118 | |
| 119 | 119 | |
| 120 | - public function insertInstitutionClasses($class,$count,$param){ |
|
| 121 | - try{ |
|
| 120 | + public function insertInstitutionClasses($class, $count, $param) { |
|
| 121 | + try { |
|
| 122 | 122 | |
| 123 | 123 | $academicPeriod = $param['academic_period_id']; |
| 124 | 124 | $educationGrdae = $class['education_grade_id']; |
| 125 | 125 | |
| 126 | 126 | $classId = $class['id']; |
| 127 | 127 | unset($class['id']); |
| 128 | - $institutionSubjects = Institution_subject::query()->where('education_grade_id',$class['education_grade_id']) |
|
| 129 | - ->where('institution_id',$class['institution_id']) |
|
| 130 | - ->where('academic_period_id',$academicPeriod)->get()->toArray(); |
|
| 128 | + $institutionSubjects = Institution_subject::query()->where('education_grade_id', $class['education_grade_id']) |
|
| 129 | + ->where('institution_id', $class['institution_id']) |
|
| 130 | + ->where('academic_period_id', $academicPeriod)->get()->toArray(); |
|
| 131 | 131 | $params = [ |
| 132 | 132 | 'class'=>$class, |
| 133 | 133 | 'subjects'=>$institutionSubjects, |
@@ -140,39 +140,39 @@ discard block |
||
| 140 | 140 | $class['no_of_students'] = $noOfStudents; |
| 141 | 141 | $class['created'] = now(); |
| 142 | 142 | $class['institution_shift_id'] = $param['shift_id']; |
| 143 | - $this->output->writeln('Create class:'. $class['name']); |
|
| 143 | + $this->output->writeln('Create class:'.$class['name']); |
|
| 144 | 144 | $class = Institution_class::create($class); |
| 145 | 145 | $institutionClassGrdaeObj['institution_class_id'] = $class->id; |
| 146 | 146 | $institutionClassGrdaeObj['education_grade_id'] = $educationGrdae; |
| 147 | 147 | Institution_class_grade::create($institutionClassGrdaeObj); |
| 148 | - $institutionSubjects = Institution_subject::query()->where('education_grade_id',$educationGrdae) |
|
| 149 | - ->where('institution_id',$class->institution_id) |
|
| 150 | - ->where('academic_period_id',$academicPeriod) |
|
| 148 | + $institutionSubjects = Institution_subject::query()->where('education_grade_id', $educationGrdae) |
|
| 149 | + ->where('institution_id', $class->institution_id) |
|
| 150 | + ->where('academic_period_id', $academicPeriod) |
|
| 151 | 151 | ->groupBy('education_subject_id') |
| 152 | 152 | ->get() |
| 153 | 153 | ->toArray(); |
| 154 | 154 | $params['class'] = $class; |
| 155 | - $this->insertInstitutionClassSubjects($institutionSubjects,$class); |
|
| 155 | + $this->insertInstitutionClassSubjects($institutionSubjects, $class); |
|
| 156 | 156 | // array_walk($classSubjects,array($this,'insertInstitutionClassSubjects'),$params); |
| 157 | - }catch (\Exception $e){ |
|
| 158 | - Log::error($e->getMessage(),[$e]); |
|
| 157 | + }catch (\Exception $e) { |
|
| 158 | + Log::error($e->getMessage(), [$e]); |
|
| 159 | 159 | } |
| 160 | 160 | } |
| 161 | 161 | |
| 162 | - public function insertInstitutionClassSubjects($subjects,$class){ |
|
| 163 | - if(!empty($subjects)){ |
|
| 164 | - try{ |
|
| 165 | - array_walk($subjects,array($this,'insertClassSubjects'),$class); |
|
| 166 | - $this->output->writeln('updating subjects '. $class->name); |
|
| 167 | - }catch (\Exception $e){ |
|
| 168 | - Log::error($e->getMessage(),[$e]); |
|
| 162 | + public function insertInstitutionClassSubjects($subjects, $class) { |
|
| 163 | + if (!empty($subjects)) { |
|
| 164 | + try { |
|
| 165 | + array_walk($subjects, array($this, 'insertClassSubjects'), $class); |
|
| 166 | + $this->output->writeln('updating subjects '.$class->name); |
|
| 167 | + }catch (\Exception $e) { |
|
| 168 | + Log::error($e->getMessage(), [$e]); |
|
| 169 | 169 | } |
| 170 | 170 | }; |
| 171 | 171 | } |
| 172 | 172 | |
| 173 | 173 | |
| 174 | - public function insertClassSubjects($subject,$count,$newClassId){ |
|
| 175 | - try{ |
|
| 174 | + public function insertClassSubjects($subject, $count, $newClassId) { |
|
| 175 | + try { |
|
| 176 | 176 | $subjectobj['status'] = 1; |
| 177 | 177 | $subjectobj['created_user_id'] = 1; |
| 178 | 178 | $subjectobj['created'] = now(); |
@@ -180,11 +180,11 @@ discard block |
||
| 180 | 180 | $subjectobj['institution_class_id'] = $newClassId->id; |
| 181 | 181 | $subjectobj['institution_subject_id'] = $subject['id']; |
| 182 | 182 | |
| 183 | - if(!$this->institution_class_subjects->isDuplicated($subjectobj)){ |
|
| 183 | + if (!$this->institution_class_subjects->isDuplicated($subjectobj)) { |
|
| 184 | 184 | $this->institution_class_subjects->create($subjectobj); |
| 185 | 185 | } |
| 186 | - }catch (\Exception $e){ |
|
| 187 | - Log::error($e->getMessage(),[$e]); |
|
| 186 | + }catch (\Exception $e) { |
|
| 187 | + Log::error($e->getMessage(), [$e]); |
|
| 188 | 188 | } |
| 189 | 189 | } |
| 190 | 190 | |
@@ -196,15 +196,15 @@ discard block |
||
| 196 | 196 | * @param $academicPeriod |
| 197 | 197 | * @return array |
| 198 | 198 | */ |
| 199 | - public function generateNewClass($classes,$shiftId,$academicPeriod){ |
|
| 199 | + public function generateNewClass($classes, $shiftId, $academicPeriod) { |
|
| 200 | 200 | $newClasses = []; |
| 201 | - foreach ( $classes as $class) { |
|
| 201 | + foreach ($classes as $class) { |
|
| 202 | 202 | $noOfStudents = $class['no_of_students'] == 0 ? 40 : $class['no_of_students']; |
| 203 | 203 | $class['academic_period_id'] = $academicPeriod; |
| 204 | 204 | $class['no_of_students'] = $noOfStudents; |
| 205 | 205 | $class['created'] = now(); |
| 206 | 206 | $class['institution_shift_id'] = $shiftId; |
| 207 | - array_push($newClasses,$class); |
|
| 207 | + array_push($newClasses, $class); |
|
| 208 | 208 | } |
| 209 | 209 | return $newClasses; |
| 210 | 210 | } |
@@ -215,11 +215,11 @@ discard block |
||
| 215 | 215 | * @param $shift |
| 216 | 216 | * @return mixed |
| 217 | 217 | */ |
| 218 | - public function updateShifts($year,$shift){ |
|
| 218 | + public function updateShifts($year, $shift) { |
|
| 219 | 219 | $academicPeriod = $this->academic_period->getAcademicPeriod($year); |
| 220 | - $this->shifts->where('id',$shift['id'])->update(['cloned' => $year]); |
|
| 220 | + $this->shifts->where('id', $shift['id'])->update(['cloned' => $year]); |
|
| 221 | 221 | $shift['academic_period_id'] = $academicPeriod->id; |
| 222 | 222 | $exist = $this->shifts->shiftExists($shift); |
| 223 | - return $this->shifts->create((array)$shift)->id; |
|
| 223 | + return $this->shifts->create((array) $shift)->id; |
|
| 224 | 224 | } |
| 225 | 225 | } |
@@ -48,36 +48,36 @@ discard block |
||
| 48 | 48 | public function handle() |
| 49 | 49 | { |
| 50 | 50 | $this->output->writeln('#########################################'); |
| 51 | - if($this->argument('entity') == 'class'){ |
|
| 51 | + if ($this->argument('entity') == 'class') { |
|
| 52 | 52 | $classes = Institution_class::get()->toArray(); |
| 53 | - $func = array($this,'updateCount'); |
|
| 54 | - array_walk($subjects,array($this,'process')); |
|
| 55 | - $this->output->writeln('start updating:'. count($classes)); |
|
| 56 | - }elseif($this->argument('entity') == 'subject'){ |
|
| 53 | + $func = array($this, 'updateCount'); |
|
| 54 | + array_walk($subjects, array($this, 'process')); |
|
| 55 | + $this->output->writeln('start updating:'.count($classes)); |
|
| 56 | + }elseif ($this->argument('entity') == 'subject') { |
|
| 57 | 57 | $subjects = Institution_subject::get()->toArray(); |
| 58 | - $subjects = array_chunk($subjects,10000); |
|
| 59 | - $this->output->writeln('start updating:'. count($subjects)); |
|
| 60 | - array_walk($subjects,array($this,'process')); |
|
| 58 | + $subjects = array_chunk($subjects, 10000); |
|
| 59 | + $this->output->writeln('start updating:'.count($subjects)); |
|
| 60 | + array_walk($subjects, array($this, 'process')); |
|
| 61 | 61 | $this->output->writeln('#########################################'); |
| 62 | 62 | } |
| 63 | 63 | |
| 64 | 64 | } |
| 65 | 65 | |
| 66 | - public function process($data){ |
|
| 67 | - if($this->argument('entity') == 'class'){ |
|
| 68 | - $func = array($this,'updateCount'); |
|
| 69 | - processParallel($func,$data,$this->argument('max')); |
|
| 70 | - $this->output->writeln('start updating calss count:'. count($data)); |
|
| 71 | - }elseif($this->argument('entity') == 'subject'){ |
|
| 72 | - $this->output->writeln('start updating subject count:'. count($data)); |
|
| 73 | - $func_subject = array($this,'updateSubjectCount'); |
|
| 74 | - processParallel($func_subject,$data,$this->argument('max')); |
|
| 66 | + public function process($data) { |
|
| 67 | + if ($this->argument('entity') == 'class') { |
|
| 68 | + $func = array($this, 'updateCount'); |
|
| 69 | + processParallel($func, $data, $this->argument('max')); |
|
| 70 | + $this->output->writeln('start updating calss count:'.count($data)); |
|
| 71 | + }elseif ($this->argument('entity') == 'subject') { |
|
| 72 | + $this->output->writeln('start updating subject count:'.count($data)); |
|
| 73 | + $func_subject = array($this, 'updateSubjectCount'); |
|
| 74 | + processParallel($func_subject, $data, $this->argument('max')); |
|
| 75 | 75 | } |
| 76 | 76 | } |
| 77 | 77 | |
| 78 | - public function updateCount($class){ |
|
| 79 | - $this->output->writeln('updating class:'. $class['id']); |
|
| 80 | - $totalStudents = Institution_class_student::getStudentsCount($class['id']); |
|
| 78 | + public function updateCount($class) { |
|
| 79 | + $this->output->writeln('updating class:'.$class['id']); |
|
| 80 | + $totalStudents = Institution_class_student::getStudentsCount($class['id']); |
|
| 81 | 81 | Institution_class::where('id', '=', $class['id']) |
| 82 | 82 | ->update([ |
| 83 | 83 | 'total_male_students' => $totalStudents['total_male_students'], |
@@ -85,8 +85,8 @@ discard block |
||
| 85 | 85 | ]); |
| 86 | 86 | } |
| 87 | 87 | |
| 88 | - public function updateSubjectCount($subject){ |
|
| 89 | - $this->output->writeln('updating subject:'. $subject['id']); |
|
| 88 | + public function updateSubjectCount($subject) { |
|
| 89 | + $this->output->writeln('updating subject:'.$subject['id']); |
|
| 90 | 90 | $totalStudents = Institution_subject_student::getStudentsCount($subject['id']); |
| 91 | 91 | Institution_subject::where(['id' => $subject['id']]) |
| 92 | 92 | ->update([ |
@@ -53,7 +53,7 @@ discard block |
||
| 53 | 53 | $func = array($this,'updateCount'); |
| 54 | 54 | array_walk($subjects,array($this,'process')); |
| 55 | 55 | $this->output->writeln('start updating:'. count($classes)); |
| 56 | - }elseif($this->argument('entity') == 'subject'){ |
|
| 56 | + } elseif($this->argument('entity') == 'subject'){ |
|
| 57 | 57 | $subjects = Institution_subject::get()->toArray(); |
| 58 | 58 | $subjects = array_chunk($subjects,10000); |
| 59 | 59 | $this->output->writeln('start updating:'. count($subjects)); |
@@ -68,7 +68,7 @@ discard block |
||
| 68 | 68 | $func = array($this,'updateCount'); |
| 69 | 69 | processParallel($func,$data,$this->argument('max')); |
| 70 | 70 | $this->output->writeln('start updating calss count:'. count($data)); |
| 71 | - }elseif($this->argument('entity') == 'subject'){ |
|
| 71 | + } elseif($this->argument('entity') == 'subject'){ |
|
| 72 | 72 | $this->output->writeln('start updating subject count:'. count($data)); |
| 73 | 73 | $func_subject = array($this,'updateSubjectCount'); |
| 74 | 74 | processParallel($func_subject,$data,$this->argument('max')); |
@@ -138,7 +138,7 @@ |
||
| 138 | 138 | ->join('contact_types', 'user_contacts.contact_type_id', '=', 'contact_types.id') |
| 139 | 139 | //only for UAT |
| 140 | 140 | // ->where('contact_types.contact_option_id', '=', 5) |
| 141 | - ->where('contact_types.contact_option_id', '!=', 5) |
|
| 141 | + ->where('contact_types.contact_option_id', '!=', 5) |
|
| 142 | 142 | // ->where('contact_types.name', '=', 'TestEmail') |
| 143 | 143 | ->limit(1) |
| 144 | 144 | ->get()->toArray(); |
@@ -61,12 +61,12 @@ |
||
| 61 | 61 | // dd($shift); |
| 62 | 62 | $function = array($this->clone, 'process'); |
| 63 | 63 | // array_walk($shift,$function,$params); |
| 64 | - processParallel($function,$shift, $this->argument('max'),$params); |
|
| 64 | + processParallel($function, $shift, $this->argument('max'), $params); |
|
| 65 | 65 | $this->end_time = microtime(TRUE); |
| 66 | 66 | |
| 67 | 67 | |
| 68 | 68 | $this->output->writeln('$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$'); |
| 69 | - $this->output->writeln('The cook took ' . ($this->end_time - $this->start_time) . ' seconds to complete'); |
|
| 69 | + $this->output->writeln('The cook took '.($this->end_time - $this->start_time).' seconds to complete'); |
|
| 70 | 70 | $this->output->writeln('$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$'); |
| 71 | 71 | } |
| 72 | 72 | } |
@@ -85,11 +85,11 @@ |
||
| 85 | 85 | |
| 86 | 86 | public function process($students){ |
| 87 | 87 | $type = $this->argument('type'); |
| 88 | - if($type == 'duplication'){ |
|
| 88 | + if($type == 'duplication'){ |
|
| 89 | 89 | array_walk($students,array($this,'cleanData')); |
| 90 | - }elseif($type == 'invalid' || 'all'){ |
|
| 90 | + }elseif($type == 'invalid' || 'all'){ |
|
| 91 | 91 | array_walk($students,array($this,'cleanInvalidData')); |
| 92 | - } |
|
| 92 | + } |
|
| 93 | 93 | } |
| 94 | 94 | |
| 95 | 95 | |
@@ -48,12 +48,12 @@ discard block |
||
| 48 | 48 | { |
| 49 | 49 | $type = $this->argument('type'); |
| 50 | 50 | $students = array(); |
| 51 | - if($type == 'invalid'){ |
|
| 51 | + if ($type == 'invalid') { |
|
| 52 | 52 | $students = DB::table('examination_students as es') |
| 53 | 53 | ->whereRaw('CHAR_LENGTH(nsid) > 11') |
| 54 | 54 | ->get() |
| 55 | 55 | ->toArray(); |
| 56 | - }elseif($type == 'duplicate'){ |
|
| 56 | + }elseif ($type == 'duplicate') { |
|
| 57 | 57 | $students = DB::table('institution_students as is') |
| 58 | 58 | ->join('security_users as su', 'su.id', 'is.student_id') |
| 59 | 59 | ->where('is.updated_from', 'doe') |
@@ -63,39 +63,39 @@ discard block |
||
| 63 | 63 | ->get() |
| 64 | 64 | ->toArray(); |
| 65 | 65 | |
| 66 | - }elseif('all'){ |
|
| 66 | + }elseif ('all') { |
|
| 67 | 67 | $students = DB::table('examination_students') |
| 68 | - ->where('nsid','<>','') |
|
| 68 | + ->where('nsid', '<>', '') |
|
| 69 | 69 | ->whereNotNull('nsid') |
| 70 | 70 | ->get() |
| 71 | 71 | ->toArray(); |
| 72 | 72 | } |
| 73 | 73 | |
| 74 | 74 | $this->output->writeln('###########################################------Start cleanning exam records------###########################################'); |
| 75 | - if(count($students) > 0){ |
|
| 76 | - $this->output->writeln('Total students to clean: '. count($students)); |
|
| 75 | + if (count($students) > 0) { |
|
| 76 | + $this->output->writeln('Total students to clean: '.count($students)); |
|
| 77 | 77 | $students = array_chunk($students, $this->argument('chunk')); |
| 78 | 78 | $function = array($this, 'process'); |
| 79 | - processParallel($function,$students, $this->argument('max')); |
|
| 80 | - }else{ |
|
| 79 | + processParallel($function, $students, $this->argument('max')); |
|
| 80 | + }else { |
|
| 81 | 81 | $this->output->writeln('nothing to process, all are cleaned'); |
| 82 | 82 | } |
| 83 | 83 | $this->output->writeln('###########################################------Finished cleaning exam records------###########################################'); |
| 84 | 84 | } |
| 85 | 85 | |
| 86 | - public function process($students){ |
|
| 86 | + public function process($students) { |
|
| 87 | 87 | $type = $this->argument('type'); |
| 88 | - if($type == 'duplication'){ |
|
| 89 | - array_walk($students,array($this,'cleanData')); |
|
| 90 | - }elseif($type == 'invalid' || 'all'){ |
|
| 91 | - array_walk($students,array($this,'cleanInvalidData')); |
|
| 88 | + if ($type == 'duplication') { |
|
| 89 | + array_walk($students, array($this, 'cleanData')); |
|
| 90 | + }elseif ($type == 'invalid' || 'all') { |
|
| 91 | + array_walk($students, array($this, 'cleanInvalidData')); |
|
| 92 | 92 | } |
| 93 | 93 | } |
| 94 | 94 | |
| 95 | 95 | |
| 96 | 96 | public function cleanData($Student) |
| 97 | 97 | { |
| 98 | - $exist = Examination_student::where('nsid','=', $Student->openemis_no)->count(); |
|
| 98 | + $exist = Examination_student::where('nsid', '=', $Student->openemis_no)->count(); |
|
| 99 | 99 | |
| 100 | 100 | if (!$exist) { |
| 101 | 101 | Institution_student::where('student_id', $Student->student_id)->delete(); |
@@ -108,12 +108,12 @@ discard block |
||
| 108 | 108 | public function cleanInvalidData($Student) |
| 109 | 109 | { |
| 110 | 110 | $Student = (array) $Student; |
| 111 | - $exist = Examination_student::where('nsid',$Student['nsid'])->count(); |
|
| 111 | + $exist = Examination_student::where('nsid', $Student['nsid'])->count(); |
|
| 112 | 112 | |
| 113 | 113 | $this->uniqueUId = new UniqueUid(); |
| 114 | 114 | |
| 115 | - $nsid = ltrim(rtrim($Student['nsid'],'-'),'-'); |
|
| 116 | - if(!$this->uniqueUId::isValidUniqueId('DBY-898-3J2')){ |
|
| 115 | + $nsid = ltrim(rtrim($Student['nsid'], '-'), '-'); |
|
| 116 | + if (!$this->uniqueUId::isValidUniqueId('DBY-898-3J2')) { |
|
| 117 | 117 | } |
| 118 | 118 | } |
| 119 | 119 | } |
@@ -53,7 +53,7 @@ discard block |
||
| 53 | 53 | ->whereRaw('CHAR_LENGTH(nsid) > 11') |
| 54 | 54 | ->get() |
| 55 | 55 | ->toArray(); |
| 56 | - }elseif($type == 'duplicate'){ |
|
| 56 | + } elseif($type == 'duplicate'){ |
|
| 57 | 57 | $students = DB::table('institution_students as is') |
| 58 | 58 | ->join('security_users as su', 'su.id', 'is.student_id') |
| 59 | 59 | ->where('is.updated_from', 'doe') |
@@ -63,7 +63,7 @@ discard block |
||
| 63 | 63 | ->get() |
| 64 | 64 | ->toArray(); |
| 65 | 65 | |
| 66 | - }elseif('all'){ |
|
| 66 | + } elseif('all'){ |
|
| 67 | 67 | $students = DB::table('examination_students') |
| 68 | 68 | ->where('nsid','<>','') |
| 69 | 69 | ->whereNotNull('nsid') |
@@ -77,7 +77,7 @@ discard block |
||
| 77 | 77 | $students = array_chunk($students, $this->argument('chunk')); |
| 78 | 78 | $function = array($this, 'process'); |
| 79 | 79 | processParallel($function,$students, $this->argument('max')); |
| 80 | - }else{ |
|
| 80 | + } else{ |
|
| 81 | 81 | $this->output->writeln('nothing to process, all are cleaned'); |
| 82 | 82 | } |
| 83 | 83 | $this->output->writeln('###########################################------Finished cleaning exam records------###########################################'); |
@@ -87,7 +87,7 @@ discard block |
||
| 87 | 87 | $type = $this->argument('type'); |
| 88 | 88 | if($type == 'duplication'){ |
| 89 | 89 | array_walk($students,array($this,'cleanData')); |
| 90 | - }elseif($type == 'invalid' || 'all'){ |
|
| 90 | + } elseif($type == 'invalid' || 'all'){ |
|
| 91 | 91 | array_walk($students,array($this,'cleanInvalidData')); |
| 92 | 92 | } |
| 93 | 93 | } |
@@ -36,7 +36,7 @@ discard block |
||
| 36 | 36 | $this->output = new \Symfony\Component\Console\Output\ConsoleOutput(); |
| 37 | 37 | $this->students = new Security_user(); |
| 38 | 38 | $this->uniqueUId = new UniqueUid(); |
| 39 | - $this->max = 0; |
|
| 39 | + $this->max = 0; |
|
| 40 | 40 | $this->child = 0; |
| 41 | 41 | parent::__construct(); |
| 42 | 42 | } |
@@ -60,19 +60,19 @@ discard block |
||
| 60 | 60 | public function processParallel(array $arr, $procs = 4) |
| 61 | 61 | { |
| 62 | 62 | // Break array up into $procs chunks. |
| 63 | - $chunks = array_chunk($arr, ceil((count($arr) / $procs))); |
|
| 63 | + $chunks = array_chunk($arr, ceil((count($arr)/$procs))); |
|
| 64 | 64 | $pid = -1; |
| 65 | 65 | $children = array(); |
| 66 | 66 | foreach ($chunks as $items) { |
| 67 | 67 | $pid = pcntl_fork(); |
| 68 | 68 | if ($pid === -1) { |
| 69 | 69 | die('could not fork'); |
| 70 | - } else if ($pid === 0) { |
|
| 71 | - $this->output->writeln('started processes: ' . count($children)); |
|
| 70 | + }else if ($pid === 0) { |
|
| 71 | + $this->output->writeln('started processes: '.count($children)); |
|
| 72 | 72 | // We are the child process. Pass a chunk of items to process. |
| 73 | 73 | array_walk($items, array($this, 'process')); |
| 74 | 74 | exit(0); |
| 75 | - } else { |
|
| 75 | + }else { |
|
| 76 | 76 | // We are the parent. |
| 77 | 77 | $children[] = $pid; |
| 78 | 78 | } |
@@ -104,17 +104,17 @@ discard block |
||
| 104 | 104 | |
| 105 | 105 | $newId = $this->uniqueUId::getUniqueAlphanumeric(); |
| 106 | 106 | $student['openemis_no'] = $newId; |
| 107 | - $student = $this->uniqueUserId->updateOrInsertRecord($student); |
|
| 107 | + $student = $this->uniqueUserId->updateOrInsertRecord($student); |
|
| 108 | 108 | // $this->output->writeln('New NSID generated for :' . $student['id']); |
| 109 | 109 | Security_user::query()->where('id', $student['id']) |
| 110 | 110 | ->update(['openemis_no' => $newId, 'username' => str_replace('-', '', $newId)]); |
| 111 | - } catch (\Exception $e) { |
|
| 111 | + }catch (\Exception $e) { |
|
| 112 | 112 | } |
| 113 | - } else { |
|
| 113 | + }else { |
|
| 114 | 114 | try { |
| 115 | 115 | // $this->output->writeln('Updating student:' . $student['id']); |
| 116 | 116 | $this->uniqueUserId->updateOrInsertRecord($student); |
| 117 | - } catch (\Exception $e) { |
|
| 117 | + }catch (\Exception $e) { |
|
| 118 | 118 | dd($e); |
| 119 | 119 | } |
| 120 | 120 | } |
@@ -54,7 +54,7 @@ discard block |
||
| 54 | 54 | |
| 55 | 55 | public function updateOrInsertRecord($user) |
| 56 | 56 | { |
| 57 | - try { |
|
| 57 | + try { |
|
| 58 | 58 | // regenerate unique id if it's not available |
| 59 | 59 | $uniqueId = $this->uniqueUserId::isValidUniqueId($user['openemis_no'],9) ? $this->uniqueUserId::getUniqueAlphanumeric() : $user['openemis_no']; |
| 60 | 60 | |
@@ -69,9 +69,9 @@ discard block |
||
| 69 | 69 | ]); |
| 70 | 70 | } |
| 71 | 71 | return $user; |
| 72 | - } catch (\Exception $th) { |
|
| 73 | - $user['openemis_no'] = $this->uniqueUserId::getUniqueAlphanumeric(); |
|
| 74 | - $this->updateOrInsertRecord($user); |
|
| 75 | - } |
|
| 72 | + } catch (\Exception $th) { |
|
| 73 | + $user['openemis_no'] = $this->uniqueUserId::getUniqueAlphanumeric(); |
|
| 74 | + $this->updateOrInsertRecord($user); |
|
| 75 | + } |
|
| 76 | 76 | } |
| 77 | 77 | } |
@@ -56,10 +56,10 @@ discard block |
||
| 56 | 56 | { |
| 57 | 57 | try { |
| 58 | 58 | // regenerate unique id if it's not available |
| 59 | - $uniqueId = $this->uniqueUserId::isValidUniqueId($user['openemis_no'],9) ? $this->uniqueUserId::getUniqueAlphanumeric() : $user['openemis_no']; |
|
| 59 | + $uniqueId = $this->uniqueUserId::isValidUniqueId($user['openemis_no'], 9) ? $this->uniqueUserId::getUniqueAlphanumeric() : $user['openemis_no']; |
|
| 60 | 60 | |
| 61 | 61 | //check if the user's entry exits ? |
| 62 | - $exists = Unique_user_id::where('unique_id' , $uniqueId)->exists(); |
|
| 62 | + $exists = Unique_user_id::where('unique_id', $uniqueId)->exists(); |
|
| 63 | 63 | |
| 64 | 64 | if (!$exists) { |
| 65 | 65 | // try to feed unique user id |
@@ -69,7 +69,7 @@ discard block |
||
| 69 | 69 | ]); |
| 70 | 70 | } |
| 71 | 71 | return $user; |
| 72 | - } catch (\Exception $th) { |
|
| 72 | + }catch (\Exception $th) { |
|
| 73 | 73 | $user['openemis_no'] = $this->uniqueUserId::getUniqueAlphanumeric(); |
| 74 | 74 | $this->updateOrInsertRecord($user); |
| 75 | 75 | } |
@@ -4,7 +4,7 @@ discard block |
||
| 4 | 4 | |
| 5 | 5 | use Illuminate\Database\Eloquent\Model; |
| 6 | 6 | |
| 7 | -class Institution_subject extends Base_Model { |
|
| 7 | +class Institution_subject extends Base_Model { |
|
| 8 | 8 | |
| 9 | 9 | /** |
| 10 | 10 | * The database table used by the model. |
@@ -42,42 +42,42 @@ discard block |
||
| 42 | 42 | protected $dates = ['modified', 'created', 'modified', 'created']; |
| 43 | 43 | |
| 44 | 44 | |
| 45 | - public function institutionGradeSubject(){ |
|
| 46 | - return $this->belongsTo('App\Models\Education_grades_subject','education_subject_id','education_subject_id'); |
|
| 45 | + public function institutionGradeSubject() { |
|
| 46 | + return $this->belongsTo('App\Models\Education_grades_subject', 'education_subject_id', 'education_subject_id'); |
|
| 47 | 47 | } |
| 48 | 48 | |
| 49 | - public function institutionOptionalGradeSubject(){ |
|
| 50 | - return $this->belongsTo('App\Models\Education_grades_subject','education_grade_id','education_grade_id'); |
|
| 49 | + public function institutionOptionalGradeSubject() { |
|
| 50 | + return $this->belongsTo('App\Models\Education_grades_subject', 'education_grade_id', 'education_grade_id'); |
|
| 51 | 51 | } |
| 52 | 52 | |
| 53 | - public function institutionMandatoryGradeSubject(){ |
|
| 54 | - return $this->belongsTo('App\Models\Education_grades_subject','education_grade_id','education_grade_id'); |
|
| 53 | + public function institutionMandatoryGradeSubject() { |
|
| 54 | + return $this->belongsTo('App\Models\Education_grades_subject', 'education_grade_id', 'education_grade_id'); |
|
| 55 | 55 | } |
| 56 | 56 | |
| 57 | 57 | |
| 58 | - public function institutionClassSubject(){ |
|
| 59 | - return $this->hasMany('App\Models\Institution_class_subject','institution_class_id','id'); |
|
| 58 | + public function institutionClassSubject() { |
|
| 59 | + return $this->hasMany('App\Models\Institution_class_subject', 'institution_class_id', 'id'); |
|
| 60 | 60 | } |
| 61 | 61 | |
| 62 | 62 | |
| 63 | 63 | |
| 64 | - public function getInstitutionSubjects($institution_id,$academic_period_id){ |
|
| 65 | - return self::query()->where('institution_id',$institution_id) |
|
| 66 | - ->where('academic_period_id',$academic_period_id) |
|
| 64 | + public function getInstitutionSubjects($institution_id, $academic_period_id) { |
|
| 65 | + return self::query()->where('institution_id', $institution_id) |
|
| 66 | + ->where('academic_period_id', $academic_period_id) |
|
| 67 | 67 | ->get()->toArray(); |
| 68 | 68 | } |
| 69 | 69 | |
| 70 | 70 | public static function getStudentsCount($institution_subject_id) |
| 71 | 71 | { |
| 72 | - $total_male_students = self::with(['student' => function ($query) { |
|
| 72 | + $total_male_students = self::with(['student' => function($query) { |
|
| 73 | 73 | $query->where('student.gender_id', '=', 1); |
| 74 | - }])->whereHas('student', function ($query) { |
|
| 74 | + }])->whereHas('student', function($query) { |
|
| 75 | 75 | $query->where('gender_id', '=', 1); |
| 76 | 76 | })->where('institution_subject_id', '=', $institution_subject_id)->count(); |
| 77 | 77 | |
| 78 | - $total_female_students = self::with(['student' => function ($query) { |
|
| 78 | + $total_female_students = self::with(['student' => function($query) { |
|
| 79 | 79 | $query->where('student.gender_id', '=', 2); |
| 80 | - }])->whereHas('student', function ($query) { |
|
| 80 | + }])->whereHas('student', function($query) { |
|
| 81 | 81 | $query->where('gender_id', '=', 2); |
| 82 | 82 | })->where('institution_subject_id', '=', $institution_subject_id)->count(); |
| 83 | 83 | |
@@ -149,9 +149,9 @@ discard block |
||
| 149 | 149 | public function getMatches($student) |
| 150 | 150 | { |
| 151 | 151 | return $this |
| 152 | - ->where('gender_id',$student['gender'] + 1) |
|
| 153 | - ->where('institutions.code',$student['schoolid']) |
|
| 154 | - ->where('date_of_birth',$student['b_date']) |
|
| 152 | + ->where('gender_id', $student['gender'] + 1) |
|
| 153 | + ->where('institutions.code', $student['schoolid']) |
|
| 154 | + ->where('date_of_birth', $student['b_date']) |
|
| 155 | 155 | ->join('institution_students', 'security_users.id', 'institution_students.student_id') |
| 156 | 156 | ->join('institutions', 'institution_students.institution_id', 'institutions.id') |
| 157 | 157 | ->get()->toArray(); |
@@ -166,9 +166,9 @@ discard block |
||
| 166 | 166 | public function getStudentCount($student) |
| 167 | 167 | { |
| 168 | 168 | return $this |
| 169 | - ->where('gender_id',$student['gender'] + 1) |
|
| 170 | - ->where('institutions.code',$student['schoolid']) |
|
| 171 | - ->where('date_of_birth',$student['b_date']) |
|
| 169 | + ->where('gender_id', $student['gender'] + 1) |
|
| 170 | + ->where('institutions.code', $student['schoolid']) |
|
| 171 | + ->where('date_of_birth', $student['b_date']) |
|
| 172 | 172 | ->join('institution_students', 'security_users.id', 'institution_students.student_id') |
| 173 | 173 | ->join('institutions', 'institution_students.institution_id', 'institutions.id') |
| 174 | 174 | ->count(); |
@@ -202,7 +202,7 @@ discard block |
||
| 202 | 202 | $id = $this->insertGetId($studentData); |
| 203 | 203 | $studentData['id'] = $id; |
| 204 | 204 | return $studentData; |
| 205 | - } catch (\Exception $th) { |
|
| 205 | + }catch (\Exception $th) { |
|
| 206 | 206 | Log::error($th->getMessage()); |
| 207 | 207 | // in case of duplication of the Unique ID this will recursive. |
| 208 | 208 | $sis_student['openemis_no'] = $this->uniqueUId::getUniqueAlphanumeric(); |
@@ -223,7 +223,7 @@ discard block |
||
| 223 | 223 | $this->uniqueUserId = new Unique_user_id(); |
| 224 | 224 | $this->uniqueUId = new UniqueUid(); |
| 225 | 225 | // regenerate unique id if it's not available |
| 226 | - $uniqueId = ($this->uniqueUId::isValidUniqueId($sis_student['openemis_no'],9)) ? $sis_student['openemis_no'] : $this->uniqueUId::getUniqueAlphanumeric(); |
|
| 226 | + $uniqueId = ($this->uniqueUId::isValidUniqueId($sis_student['openemis_no'], 9)) ? $sis_student['openemis_no'] : $this->uniqueUId::getUniqueAlphanumeric(); |
|
| 227 | 227 | |
| 228 | 228 | $studentData = [ |
| 229 | 229 | 'username' => str_replace('-', '', $uniqueId), |
@@ -238,10 +238,10 @@ discard block |
||
| 238 | 238 | |
| 239 | 239 | try { |
| 240 | 240 | $this->uniqueUserId->updateOrInsertRecord($studentData); |
| 241 | - self::where( 'id' , $sis_student['student_id'])->update($studentData); |
|
| 241 | + self::where('id', $sis_student['student_id'])->update($studentData); |
|
| 242 | 242 | $studentData['id'] = $sis_student['student_id']; |
| 243 | 243 | return $studentData; |
| 244 | - } catch (\Exception $th) { |
|
| 244 | + }catch (\Exception $th) { |
|
| 245 | 245 | Log::error($th); |
| 246 | 246 | // in case of duplication of the Unique ID this will recursive. |
| 247 | 247 | $sis_student['openemis_no'] = $this->uniqueUId::getUniqueAlphanumeric(); |