@@ -39,17 +39,17 @@ |
||
39 | 39 | */ |
40 | 40 | public function handle() |
41 | 41 | { |
42 | - ini_set('memory_limit','2048'); |
|
42 | + ini_set('memory_limit', '2048'); |
|
43 | 43 | $institutions = $this->instituions->all()->chunk(50)->toArray(); |
44 | - array_walk($institutions,array($this,'addInstitutionStudents')); |
|
44 | + array_walk($institutions, array($this, 'addInstitutionStudents')); |
|
45 | 45 | } |
46 | 46 | |
47 | - protected function addInstitutionStudents($chunk){ |
|
48 | - array_walk($chunk,array($this,'callFunction')); |
|
47 | + protected function addInstitutionStudents($chunk) { |
|
48 | + array_walk($chunk, array($this, 'callFunction')); |
|
49 | 49 | |
50 | 50 | } |
51 | 51 | |
52 | - protected function callFunction($institution){ |
|
53 | - $this->call('admission:students',['institution' => $institution['code']]); |
|
52 | + protected function callFunction($institution) { |
|
53 | + $this->call('admission:students', ['institution' => $institution['code']]); |
|
54 | 54 | } |
55 | 55 | } |
@@ -76,9 +76,9 @@ discard block |
||
76 | 76 | $this->end_time = microtime(TRUE); |
77 | 77 | |
78 | 78 | |
79 | - $this->output->writeln('$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$'); |
|
80 | - $this->output->writeln('The cook took ' . ($this->end_time - $this->start_time) . ' seconds to complete'); |
|
81 | - $this->output->writeln('$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$'); |
|
79 | + $this->output->writeln('$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$'); |
|
80 | + $this->output->writeln('The cook took ' . ($this->end_time - $this->start_time) . ' seconds to complete'); |
|
81 | + $this->output->writeln('$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$'); |
|
82 | 82 | |
83 | 83 | } |
84 | 84 | |
@@ -113,13 +113,13 @@ discard block |
||
113 | 113 | $this->output->writeln('updating from '. $shiftId); |
114 | 114 | |
115 | 115 | }catch (\Exception $e){ |
116 | - Log::error($e->getMessage(),[$e]); |
|
116 | + Log::error($e->getMessage(),[$e]); |
|
117 | 117 | } |
118 | 118 | } |
119 | 119 | // DB::commit(); |
120 | 120 | }catch (\Exception $e){ |
121 | 121 | // DB::rollBack(); |
122 | - Log::error($e->getMessage(),[$e]); |
|
122 | + Log::error($e->getMessage(),[$e]); |
|
123 | 123 | } |
124 | 124 | } |
125 | 125 | |
@@ -130,16 +130,16 @@ discard block |
||
130 | 130 | * @param $academicPeriod |
131 | 131 | */ |
132 | 132 | public function insertInstitutionSubjects($subjects, $count,$academicPeriod){ |
133 | - try{ |
|
134 | - $subjects['academic_period_id'] = $academicPeriod->id; |
|
135 | - $subjects['created'] = now(); |
|
136 | - unset($subjects['total_male_students']); |
|
137 | - unset($subjects['total_female_students']); |
|
138 | - unset($subjects['id']); |
|
139 | - $classSubject = Institution_subject::create($subjects); |
|
140 | - }catch (\Exception $e){ |
|
133 | + try{ |
|
134 | + $subjects['academic_period_id'] = $academicPeriod->id; |
|
135 | + $subjects['created'] = now(); |
|
136 | + unset($subjects['total_male_students']); |
|
137 | + unset($subjects['total_female_students']); |
|
138 | + unset($subjects['id']); |
|
139 | + $classSubject = Institution_subject::create($subjects); |
|
140 | + }catch (\Exception $e){ |
|
141 | 141 | Log::error($e->getMessage(),[$e]); |
142 | - } |
|
142 | + } |
|
143 | 143 | } |
144 | 144 | |
145 | 145 | |
@@ -181,7 +181,7 @@ discard block |
||
181 | 181 | $this->insertInstitutionClassSubjects($institutionSubjects,$class); |
182 | 182 | // array_walk($classSubjects,array($this,'insertInstitutionClassSubjects'),$params); |
183 | 183 | }catch (\Exception $e){ |
184 | - Log::error($e->getMessage(),[$e]); |
|
184 | + Log::error($e->getMessage(),[$e]); |
|
185 | 185 | } |
186 | 186 | } |
187 | 187 | |
@@ -191,7 +191,7 @@ discard block |
||
191 | 191 | array_walk($subjects,array($this,'insertClassSubjects'),$class); |
192 | 192 | $this->output->writeln('updating subjects '. $class->name); |
193 | 193 | }catch (\Exception $e){ |
194 | - Log::error($e->getMessage(),[$e]); |
|
194 | + Log::error($e->getMessage(),[$e]); |
|
195 | 195 | } |
196 | 196 | }; |
197 | 197 | } |
@@ -209,7 +209,7 @@ discard block |
||
209 | 209 | $this->institution_class_subjects->create($subjectobj); |
210 | 210 | } |
211 | 211 | }catch (\Exception $e){ |
212 | - Log::error($e->getMessage(),[$e]); |
|
212 | + Log::error($e->getMessage(),[$e]); |
|
213 | 213 | } |
214 | 214 | } |
215 | 215 |
@@ -48,8 +48,8 @@ discard block |
||
48 | 48 | $this->academic_period = new Academic_period(); |
49 | 49 | $this->institution_classes = new Institution_class(); |
50 | 50 | $this->institution_class_subjects = new Institution_class_subject(); |
51 | - $this->institution_subjects = new Institution_subject(); |
|
52 | - $this->education_grade_subjects = new Education_grades_subject(); |
|
51 | + $this->institution_subjects = new Institution_subject(); |
|
52 | + $this->education_grade_subjects = new Education_grades_subject(); |
|
53 | 53 | $this->output = new \Symfony\Component\Console\Output\ConsoleOutput(); |
54 | 54 | } |
55 | 55 | |
@@ -72,33 +72,33 @@ discard block |
||
72 | 72 | 'previous_academic_period' => $previousAcademicPeriod |
73 | 73 | ]; |
74 | 74 | // dd($shift); |
75 | - array_walk($shift,array($this,'process'),$params); |
|
75 | + array_walk($shift, array($this, 'process'), $params); |
|
76 | 76 | $this->end_time = microtime(TRUE); |
77 | 77 | |
78 | 78 | |
79 | 79 | $this->output->writeln('$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$'); |
80 | - $this->output->writeln('The cook took ' . ($this->end_time - $this->start_time) . ' seconds to complete'); |
|
80 | + $this->output->writeln('The cook took '.($this->end_time - $this->start_time).' seconds to complete'); |
|
81 | 81 | $this->output->writeln('$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$'); |
82 | 82 | |
83 | 83 | } |
84 | 84 | |
85 | - public function array_walk($shift,$count,$params){ |
|
86 | - array_walk($shift,array($this,'process'),$params); |
|
85 | + public function array_walk($shift, $count, $params) { |
|
86 | + array_walk($shift, array($this, 'process'), $params); |
|
87 | 87 | } |
88 | 88 | |
89 | - public function process($shift,$count,$params){ |
|
89 | + public function process($shift, $count, $params) { |
|
90 | 90 | $year = $params['year']; |
91 | 91 | $academicPeriod = $params['academic_period']; |
92 | 92 | $previousAcademicPeriod = $params['previous_academic_period']; |
93 | 93 | // DB::beginTransaction(); |
94 | - try{ |
|
94 | + try { |
|
95 | 95 | $shiftId = $this->updateShifts($year, $shift); |
96 | 96 | $institutionClasses = $this->institution_classes->getShiftClasses($shift['id']); |
97 | 97 | $institutionSubjects = $this->education_grade_subjects->getInstitutionSubjects($shift['institution_id']); |
98 | - array_walk($institutionSubjects , array($this,'insertInstitutionSubjects'),$academicPeriod); |
|
99 | - if (!empty($institutionClasses) && !is_null($shiftId) && !is_null($academicPeriod) ) { |
|
98 | + array_walk($institutionSubjects, array($this, 'insertInstitutionSubjects'), $academicPeriod); |
|
99 | + if (!empty($institutionClasses) && !is_null($shiftId) && !is_null($academicPeriod)) { |
|
100 | 100 | |
101 | - $newInstitutionClasses = $this->generateNewClass($institutionClasses,$shiftId,$academicPeriod->id); |
|
101 | + $newInstitutionClasses = $this->generateNewClass($institutionClasses, $shiftId, $academicPeriod->id); |
|
102 | 102 | |
103 | 103 | $params = [ |
104 | 104 | 'previous_academic_period_id' => $previousAcademicPeriod->id, |
@@ -106,20 +106,20 @@ discard block |
||
106 | 106 | 'shift_id' =>$shiftId |
107 | 107 | ]; |
108 | 108 | |
109 | - try{ |
|
110 | - array_walk($newInstitutionClasses,array($this,'insertInstitutionClasses'),$params); |
|
109 | + try { |
|
110 | + array_walk($newInstitutionClasses, array($this, 'insertInstitutionClasses'), $params); |
|
111 | 111 | $newInstitutionClasses = $this->institution_classes->getShiftClasses($shiftId); |
112 | 112 | $this->output->writeln('##########################################################################################################################'); |
113 | - $this->output->writeln('updating from '. $shiftId); |
|
113 | + $this->output->writeln('updating from '.$shiftId); |
|
114 | 114 | |
115 | - }catch (\Exception $e){ |
|
116 | - Log::error($e->getMessage(),[$e]); |
|
115 | + }catch (\Exception $e) { |
|
116 | + Log::error($e->getMessage(), [$e]); |
|
117 | 117 | } |
118 | 118 | } |
119 | 119 | // DB::commit(); |
120 | - }catch (\Exception $e){ |
|
120 | + }catch (\Exception $e) { |
|
121 | 121 | // DB::rollBack(); |
122 | - Log::error($e->getMessage(),[$e]); |
|
122 | + Log::error($e->getMessage(), [$e]); |
|
123 | 123 | } |
124 | 124 | } |
125 | 125 | |
@@ -129,31 +129,31 @@ discard block |
||
129 | 129 | * @param $count |
130 | 130 | * @param $academicPeriod |
131 | 131 | */ |
132 | - public function insertInstitutionSubjects($subjects, $count,$academicPeriod){ |
|
133 | - try{ |
|
132 | + public function insertInstitutionSubjects($subjects, $count, $academicPeriod) { |
|
133 | + try { |
|
134 | 134 | $subjects['academic_period_id'] = $academicPeriod->id; |
135 | 135 | $subjects['created'] = now(); |
136 | 136 | unset($subjects['total_male_students']); |
137 | 137 | unset($subjects['total_female_students']); |
138 | 138 | unset($subjects['id']); |
139 | 139 | $classSubject = Institution_subject::create($subjects); |
140 | - }catch (\Exception $e){ |
|
141 | - Log::error($e->getMessage(),[$e]); |
|
140 | + }catch (\Exception $e) { |
|
141 | + Log::error($e->getMessage(), [$e]); |
|
142 | 142 | } |
143 | 143 | } |
144 | 144 | |
145 | 145 | |
146 | - public function insertInstitutionClasses($class,$count,$param){ |
|
147 | - try{ |
|
146 | + public function insertInstitutionClasses($class, $count, $param) { |
|
147 | + try { |
|
148 | 148 | |
149 | 149 | $academicPeriod = $param['academic_period_id']; |
150 | 150 | $educationGrdae = $class['education_grade_id']; |
151 | 151 | |
152 | 152 | $classId = $class['id']; |
153 | 153 | unset($class['id']); |
154 | - $institutionSubjects = Institution_subject::query()->where('education_grade_id',$class['education_grade_id']) |
|
155 | - ->where('institution_id',$class['institution_id']) |
|
156 | - ->where('academic_period_id',$academicPeriod)->get()->toArray(); |
|
154 | + $institutionSubjects = Institution_subject::query()->where('education_grade_id', $class['education_grade_id']) |
|
155 | + ->where('institution_id', $class['institution_id']) |
|
156 | + ->where('academic_period_id', $academicPeriod)->get()->toArray(); |
|
157 | 157 | $params = [ |
158 | 158 | 'class'=>$class, |
159 | 159 | 'subjects'=>$institutionSubjects, |
@@ -166,38 +166,38 @@ discard block |
||
166 | 166 | $class['no_of_students'] = $noOfStudents; |
167 | 167 | $class['created'] = now(); |
168 | 168 | $class['institution_shift_id'] = $param['shift_id']; |
169 | - $this->output->writeln('Create class:'. $class['name']); |
|
169 | + $this->output->writeln('Create class:'.$class['name']); |
|
170 | 170 | $class = Institution_class::create($class); |
171 | 171 | $institutionClassGrdaeObj['institution_class_id'] = $class->id; |
172 | 172 | $institutionClassGrdaeObj['education_grade_id'] = $educationGrdae; |
173 | 173 | Institution_class_grade::create($institutionClassGrdaeObj); |
174 | - $institutionSubjects = Institution_subject::query()->where('education_grade_id',$educationGrdae) |
|
175 | - ->where('institution_id',$class->institution_id) |
|
176 | - ->where('academic_period_id',$academicPeriod) |
|
174 | + $institutionSubjects = Institution_subject::query()->where('education_grade_id', $educationGrdae) |
|
175 | + ->where('institution_id', $class->institution_id) |
|
176 | + ->where('academic_period_id', $academicPeriod) |
|
177 | 177 | ->groupBy('education_subject_id') |
178 | 178 | ->get() |
179 | 179 | ->toArray(); |
180 | 180 | $params['class'] = $class; |
181 | - $this->insertInstitutionClassSubjects($institutionSubjects,$class); |
|
181 | + $this->insertInstitutionClassSubjects($institutionSubjects, $class); |
|
182 | 182 | // array_walk($classSubjects,array($this,'insertInstitutionClassSubjects'),$params); |
183 | - }catch (\Exception $e){ |
|
184 | - Log::error($e->getMessage(),[$e]); |
|
183 | + }catch (\Exception $e) { |
|
184 | + Log::error($e->getMessage(), [$e]); |
|
185 | 185 | } |
186 | 186 | } |
187 | 187 | |
188 | - public function insertInstitutionClassSubjects($subjects,$class){ |
|
189 | - if(!empty($subjects)){ |
|
190 | - try{ |
|
191 | - array_walk($subjects,array($this,'insertClassSubjects'),$class); |
|
192 | - $this->output->writeln('updating subjects '. $class->name); |
|
193 | - }catch (\Exception $e){ |
|
194 | - Log::error($e->getMessage(),[$e]); |
|
188 | + public function insertInstitutionClassSubjects($subjects, $class) { |
|
189 | + if (!empty($subjects)) { |
|
190 | + try { |
|
191 | + array_walk($subjects, array($this, 'insertClassSubjects'), $class); |
|
192 | + $this->output->writeln('updating subjects '.$class->name); |
|
193 | + }catch (\Exception $e) { |
|
194 | + Log::error($e->getMessage(), [$e]); |
|
195 | 195 | } |
196 | 196 | }; |
197 | 197 | } |
198 | 198 | |
199 | - public function insertClassSubjects($subject,$count,$newClassId){ |
|
200 | - try{ |
|
199 | + public function insertClassSubjects($subject, $count, $newClassId) { |
|
200 | + try { |
|
201 | 201 | $subjectobj['status'] = 1; |
202 | 202 | $subjectobj['created_user_id'] = 1; |
203 | 203 | $subjectobj['created'] = now(); |
@@ -205,11 +205,11 @@ discard block |
||
205 | 205 | $subjectobj['institution_class_id'] = $newClassId->id; |
206 | 206 | $subjectobj['institution_subject_id'] = $subject['id']; |
207 | 207 | |
208 | - if(!$this->institution_class_subjects->isDuplicated($subjectobj)){ |
|
208 | + if (!$this->institution_class_subjects->isDuplicated($subjectobj)) { |
|
209 | 209 | $this->institution_class_subjects->create($subjectobj); |
210 | 210 | } |
211 | - }catch (\Exception $e){ |
|
212 | - Log::error($e->getMessage(),[$e]); |
|
211 | + }catch (\Exception $e) { |
|
212 | + Log::error($e->getMessage(), [$e]); |
|
213 | 213 | } |
214 | 214 | } |
215 | 215 | |
@@ -221,15 +221,15 @@ discard block |
||
221 | 221 | * @param $academicPeriod |
222 | 222 | * @return array |
223 | 223 | */ |
224 | - public function generateNewClass($classes,$shiftId,$academicPeriod){ |
|
224 | + public function generateNewClass($classes, $shiftId, $academicPeriod) { |
|
225 | 225 | $newClasses = []; |
226 | - foreach ( $classes as $class) { |
|
226 | + foreach ($classes as $class) { |
|
227 | 227 | $noOfStudents = $class['no_of_students'] == 0 ? 40 : $class['no_of_students']; |
228 | 228 | $class['academic_period_id'] = $academicPeriod; |
229 | 229 | $class['no_of_students'] = $noOfStudents; |
230 | 230 | $class['created'] = now(); |
231 | 231 | $class['institution_shift_id'] = $shiftId; |
232 | - array_push($newClasses,$class); |
|
232 | + array_push($newClasses, $class); |
|
233 | 233 | } |
234 | 234 | return $newClasses; |
235 | 235 | } |
@@ -240,11 +240,11 @@ discard block |
||
240 | 240 | * @param $shift |
241 | 241 | * @return mixed |
242 | 242 | */ |
243 | - public function updateShifts($year,$shift){ |
|
243 | + public function updateShifts($year, $shift) { |
|
244 | 244 | $academicPeriod = $this->academic_period->getAcademicPeriod($year); |
245 | - $this->shifts->where('id',$shift['id'])->update(['cloned' => '2020']); |
|
245 | + $this->shifts->where('id', $shift['id'])->update(['cloned' => '2020']); |
|
246 | 246 | $shift['academic_period_id'] = $academicPeriod->id; |
247 | 247 | $exist = $this->shifts->shiftExists($shift); |
248 | - return $this->shifts->create((array)$shift)->id; |
|
248 | + return $this->shifts->create((array) $shift)->id; |
|
249 | 249 | } |
250 | 250 | } |
@@ -112,12 +112,12 @@ discard block |
||
112 | 112 | $this->output->writeln('##########################################################################################################################'); |
113 | 113 | $this->output->writeln('updating from '. $shiftId); |
114 | 114 | |
115 | - }catch (\Exception $e){ |
|
115 | + } catch (\Exception $e){ |
|
116 | 116 | Log::error($e->getMessage(),[$e]); |
117 | 117 | } |
118 | 118 | } |
119 | 119 | // DB::commit(); |
120 | - }catch (\Exception $e){ |
|
120 | + } catch (\Exception $e){ |
|
121 | 121 | // DB::rollBack(); |
122 | 122 | Log::error($e->getMessage(),[$e]); |
123 | 123 | } |
@@ -137,7 +137,7 @@ discard block |
||
137 | 137 | unset($subjects['total_female_students']); |
138 | 138 | unset($subjects['id']); |
139 | 139 | $classSubject = Institution_subject::create($subjects); |
140 | - }catch (\Exception $e){ |
|
140 | + } catch (\Exception $e){ |
|
141 | 141 | Log::error($e->getMessage(),[$e]); |
142 | 142 | } |
143 | 143 | } |
@@ -180,7 +180,7 @@ discard block |
||
180 | 180 | $params['class'] = $class; |
181 | 181 | $this->insertInstitutionClassSubjects($institutionSubjects,$class); |
182 | 182 | // array_walk($classSubjects,array($this,'insertInstitutionClassSubjects'),$params); |
183 | - }catch (\Exception $e){ |
|
183 | + } catch (\Exception $e){ |
|
184 | 184 | Log::error($e->getMessage(),[$e]); |
185 | 185 | } |
186 | 186 | } |
@@ -190,7 +190,7 @@ discard block |
||
190 | 190 | try{ |
191 | 191 | array_walk($subjects,array($this,'insertClassSubjects'),$class); |
192 | 192 | $this->output->writeln('updating subjects '. $class->name); |
193 | - }catch (\Exception $e){ |
|
193 | + } catch (\Exception $e){ |
|
194 | 194 | Log::error($e->getMessage(),[$e]); |
195 | 195 | } |
196 | 196 | }; |
@@ -208,7 +208,7 @@ discard block |
||
208 | 208 | if(!$this->institution_class_subjects->isDuplicated($subjectobj)){ |
209 | 209 | $this->institution_class_subjects->create($subjectobj); |
210 | 210 | } |
211 | - }catch (\Exception $e){ |
|
211 | + } catch (\Exception $e){ |
|
212 | 212 | Log::error($e->getMessage(),[$e]); |
213 | 213 | } |
214 | 214 | } |
@@ -286,8 +286,8 @@ discard block |
||
286 | 286 | |
287 | 287 | |
288 | 288 | protected function getSheetCount($file){ |
289 | - $objPHPExcel = $this->setReader($file); |
|
290 | - return $objPHPExcel->getSheetCount(); |
|
289 | + $objPHPExcel = $this->setReader($file); |
|
290 | + return $objPHPExcel->getSheetCount(); |
|
291 | 291 | } |
292 | 292 | |
293 | 293 | |
@@ -298,8 +298,8 @@ discard block |
||
298 | 298 | * @param $column |
299 | 299 | */ |
300 | 300 | protected function import($file, $sheet, $column){ |
301 | - try { |
|
302 | - ini_set('memory_limit', '2048M'); |
|
301 | + try { |
|
302 | + ini_set('memory_limit', '2048M'); |
|
303 | 303 | $this->getFileSize($file); |
304 | 304 | $user = User::find($file['security_user_id']); |
305 | 305 | $excelFile = '/sis-bulk-data-files/' . $file['filename']; |
@@ -360,23 +360,23 @@ discard block |
||
360 | 360 | break; |
361 | 361 | } |
362 | 362 | }catch (\Maatwebsite\Excel\Validators\ValidationException $e) { |
363 | - $this->output->writeln( $e->getMessage()); |
|
364 | - if($sheet == 1){ |
|
365 | - self::writeErrors($e,$file,'Insert Students'); |
|
366 | - DB::table('uploads') |
|
367 | - ->where('id', $file['id']) |
|
368 | - ->update(['insert' => 2,'updated_at' => now()]); |
|
363 | + $this->output->writeln( $e->getMessage()); |
|
364 | + if($sheet == 1){ |
|
365 | + self::writeErrors($e,$file,'Insert Students'); |
|
366 | + DB::table('uploads') |
|
367 | + ->where('id', $file['id']) |
|
368 | + ->update(['insert' => 2,'updated_at' => now()]); |
|
369 | 369 | $this->processFailedEmail($file,$user,'Fresh Student Data Upload:Failed'); |
370 | - }else if($sheet == 2){ |
|
371 | - self::writeErrors($e,$file,'Update Students'); |
|
372 | - DB::table('uploads') |
|
373 | - ->where('id', $file['id']) |
|
374 | - ->update(['update' => 2,'updated_at' => now()]); |
|
370 | + }else if($sheet == 2){ |
|
371 | + self::writeErrors($e,$file,'Update Students'); |
|
372 | + DB::table('uploads') |
|
373 | + ->where('id', $file['id']) |
|
374 | + ->update(['update' => 2,'updated_at' => now()]); |
|
375 | 375 | $this->processFailedEmail($file,$user, 'Existing Student Data Update:Failed'); |
376 | - } |
|
377 | - DB::table('uploads') |
|
378 | - ->where('id', $file['id']) |
|
379 | - ->update(['is_processed' =>2 , 'updated_at' => now()]); |
|
376 | + } |
|
377 | + DB::table('uploads') |
|
378 | + ->where('id', $file['id']) |
|
379 | + ->update(['is_processed' =>2 , 'updated_at' => now()]); |
|
380 | 380 | |
381 | 381 | } |
382 | 382 |
@@ -47,7 +47,7 @@ discard block |
||
47 | 47 | */ |
48 | 48 | public function __construct() |
49 | 49 | { |
50 | - $this->output = new \Symfony\Component\Console\Output\ConsoleOutput(); |
|
50 | + $this->output = new \Symfony\Component\Console\Output\ConsoleOutput(); |
|
51 | 51 | parent::__construct(); |
52 | 52 | } |
53 | 53 | |
@@ -62,64 +62,64 @@ discard block |
||
62 | 62 | // if(empty($files)){ |
63 | 63 | // $files = $this->getTerminatedFiles(); |
64 | 64 | // } |
65 | - while ($this->checkTime()){ |
|
66 | - if($this->checkTime()){ |
|
65 | + while ($this->checkTime()) { |
|
66 | + if ($this->checkTime()) { |
|
67 | 67 | try { |
68 | - if(!empty($files)){ |
|
68 | + if (!empty($files)) { |
|
69 | 69 | $this->process($files); |
70 | 70 | unset($files); |
71 | 71 | exit(); |
72 | 72 | |
73 | - }else{ |
|
73 | + }else { |
|
74 | 74 | $output = new \Symfony\Component\Console\Output\ConsoleOutput(); |
75 | 75 | $this->output->writeln('No files found,Waiting for files'); |
76 | 76 | exit(); |
77 | 77 | |
78 | 78 | } |
79 | 79 | |
80 | - }catch (Exception $e){ |
|
80 | + }catch (Exception $e) { |
|
81 | 81 | $output = new \Symfony\Component\Console\Output\ConsoleOutput(); |
82 | 82 | $this->output->writeln($e); |
83 | 83 | sleep(300); |
84 | 84 | $this->handle(); |
85 | 85 | |
86 | 86 | } |
87 | - }else{ |
|
87 | + }else { |
|
88 | 88 | exit(); |
89 | 89 | } |
90 | 90 | } |
91 | 91 | } |
92 | 92 | |
93 | 93 | |
94 | - protected function process($files){ |
|
94 | + protected function process($files) { |
|
95 | 95 | $time = Carbon::now()->tz('Asia/Colombo'); |
96 | 96 | // array_walk($files, array($this,'processSheet')); |
97 | 97 | $node = $this->argument('node'); |
98 | 98 | $files[0]['node'] = $node; |
99 | 99 | $this->processSheet($files[0]); |
100 | 100 | $now = Carbon::now()->tz('Asia/Colombo'); |
101 | - $this->output->writeln('=============== Time taken to batch ' .$now->diffInMinutes($time)); |
|
101 | + $this->output->writeln('=============== Time taken to batch '.$now->diffInMinutes($time)); |
|
102 | 102 | |
103 | 103 | } |
104 | 104 | |
105 | - protected function getTerminatedFiles(){ |
|
105 | + protected function getTerminatedFiles() { |
|
106 | 106 | $files = Upload::where('is_processed', '=', 3) |
107 | 107 | ->where('updated_at', '<=', Carbon::now()->tz('Asia/Colombo')->subHours(3)) |
108 | 108 | ->limit(1) |
109 | - ->orderBy('updated_at','desc') |
|
109 | + ->orderBy('updated_at', 'desc') |
|
110 | 110 | ->get()->toArray(); |
111 | - if(!empty($files)){ |
|
111 | + if (!empty($files)) { |
|
112 | 112 | $this->output->writeln('******************* Processing a terminated file **********************'); |
113 | 113 | DB::beginTransaction(); |
114 | 114 | DB::table('uploads') |
115 | 115 | ->where('id', $files[0]['id']) |
116 | - ->update(['is_processed' => 4,'updated_at' => now()]); |
|
116 | + ->update(['is_processed' => 4, 'updated_at' => now()]); |
|
117 | 117 | DB::commit(); |
118 | 118 | } |
119 | 119 | return $files; |
120 | 120 | } |
121 | 121 | |
122 | - protected function getFiles(){ |
|
122 | + protected function getFiles() { |
|
123 | 123 | $files = Upload::where('is_processed', '=', 0) |
124 | 124 | ->select('uploads.id', 'uploads.security_user_id', 'uploads.institution_class_id', 'uploads.model', |
125 | 125 | 'uploads.filename', 'uploads.is_processed', 'uploads.deleted_at', 'uploads.created_at', |
@@ -133,85 +133,85 @@ discard block |
||
133 | 133 | ->limit(1) |
134 | 134 | ->get()->toArray(); |
135 | 135 | $node = $this->argument('node'); |
136 | - if(!empty($files)){ |
|
136 | + if (!empty($files)) { |
|
137 | 137 | DB::beginTransaction(); |
138 | 138 | DB::table('uploads') |
139 | 139 | ->where('id', $files[0]['id']) |
140 | - ->update(['is_processed' => 3,'updated_at' => now(),'node' => $node]); |
|
140 | + ->update(['is_processed' => 3, 'updated_at' => now(), 'node' => $node]); |
|
141 | 141 | DB::commit(); |
142 | 142 | } |
143 | 143 | return $files; |
144 | 144 | } |
145 | 145 | |
146 | - protected function checkTime(){ |
|
146 | + protected function checkTime() { |
|
147 | 147 | $time = Carbon::now()->tz('Asia/Colombo'); |
148 | - $morning = Carbon::create($time->year, $time->month, $time->day, env('CRON_START_TIME',0), 29, 0)->tz('Asia/Colombo')->setHour(0); //set time to 05:59 |
|
148 | + $morning = Carbon::create($time->year, $time->month, $time->day, env('CRON_START_TIME', 0), 29, 0)->tz('Asia/Colombo')->setHour(0); //set time to 05:59 |
|
149 | 149 | |
150 | - $evening = Carbon::create($time->year, $time->month, $time->day, env('CRON_END_TIME',0), 30, 0)->tz('Asia/Colombo')->setHour(23); //set time to 18:00 |
|
150 | + $evening = Carbon::create($time->year, $time->month, $time->day, env('CRON_END_TIME', 0), 30, 0)->tz('Asia/Colombo')->setHour(23); //set time to 18:00 |
|
151 | 151 | |
152 | - $check = $time->between($morning,$evening, true); |
|
152 | + $check = $time->between($morning, $evening, true); |
|
153 | 153 | return true; |
154 | 154 | } |
155 | 155 | |
156 | - public function processSuccessEmail($file,$user,$subject) { |
|
156 | + public function processSuccessEmail($file, $user, $subject) { |
|
157 | 157 | $file['subject'] = $subject; |
158 | 158 | $this->output->writeln('Processing the file: '.$file['filename']); |
159 | 159 | try { |
160 | 160 | Mail::to($user->email)->send(new StudentImportSuccess($file)); |
161 | 161 | DB::table('uploads') |
162 | 162 | ->where('id', $file['id']) |
163 | - ->update(['is_processed' => 1, 'is_email_sent' => 1,'updated_at' => now()]); |
|
164 | - } catch (\Exception $ex) { |
|
165 | - $this->output->writeln( $ex->getMessage()); |
|
163 | + ->update(['is_processed' => 1, 'is_email_sent' => 1, 'updated_at' => now()]); |
|
164 | + }catch (\Exception $ex) { |
|
165 | + $this->output->writeln($ex->getMessage()); |
|
166 | 166 | DB::table('uploads') |
167 | 167 | ->where('id', $file['id']) |
168 | - ->update(['is_processed' => 1, 'is_email_sent' => 2,'updated_at' => now()]); |
|
168 | + ->update(['is_processed' => 1, 'is_email_sent' => 2, 'updated_at' => now()]); |
|
169 | 169 | } |
170 | 170 | } |
171 | 171 | |
172 | - public function processFailedEmail($file,$user,$subject) { |
|
172 | + public function processFailedEmail($file, $user, $subject) { |
|
173 | 173 | $file['subject'] = $subject; |
174 | 174 | try { |
175 | 175 | Mail::to($user->email)->send(new StudentImportFailure($file)); |
176 | 176 | DB::table('uploads') |
177 | 177 | ->where('id', $file['id']) |
178 | - ->update(['is_processed' => 2, 'is_email_sent' => 1,'updated_at' => now()]); |
|
179 | - } catch (\Exception $ex) { |
|
180 | - $this->output->writeln( $ex->getMessage()); |
|
178 | + ->update(['is_processed' => 2, 'is_email_sent' => 1, 'updated_at' => now()]); |
|
179 | + }catch (\Exception $ex) { |
|
180 | + $this->output->writeln($ex->getMessage()); |
|
181 | 181 | DB::table('uploads') |
182 | 182 | ->where('id', $file['id']) |
183 | - ->update(['is_processed' => 2, 'is_email_sent' => 2,'updated_at' => now()]); |
|
183 | + ->update(['is_processed' => 2, 'is_email_sent' => 2, 'updated_at' => now()]); |
|
184 | 184 | } |
185 | 185 | } |
186 | 186 | |
187 | - public function processEmptyEmail($file,$user,$subject) { |
|
187 | + public function processEmptyEmail($file, $user, $subject) { |
|
188 | 188 | $file['subject'] = $subject; |
189 | 189 | try { |
190 | 190 | Mail::to($user->email)->send(new EmptyFile($file)); |
191 | 191 | DB::table('uploads') |
192 | 192 | ->where('id', $file['id']) |
193 | - ->update(['is_processed' => 2, 'is_email_sent' => 1,'updated_at' => now()]); |
|
194 | - } catch (\Exception $ex) { |
|
195 | - $this->output->writeln( $ex->getMessage()); |
|
193 | + ->update(['is_processed' => 2, 'is_email_sent' => 1, 'updated_at' => now()]); |
|
194 | + }catch (\Exception $ex) { |
|
195 | + $this->output->writeln($ex->getMessage()); |
|
196 | 196 | DB::table('uploads') |
197 | 197 | ->where('id', $file['id']) |
198 | - ->update(['is_processed' => 2, 'is_email_sent' => 2,'updated_at' => now()]); |
|
198 | + ->update(['is_processed' => 2, 'is_email_sent' => 2, 'updated_at' => now()]); |
|
199 | 199 | } |
200 | 200 | } |
201 | 201 | |
202 | - protected function checkNode($file){ |
|
202 | + protected function checkNode($file) { |
|
203 | 203 | $node = $this->argument('node'); |
204 | - if($node == $file['node']){ |
|
204 | + if ($node == $file['node']) { |
|
205 | 205 | $output = new \Symfony\Component\Console\Output\ConsoleOutput(); |
206 | - $this->output->writeln('Processing from:' . $node); |
|
206 | + $this->output->writeln('Processing from:'.$node); |
|
207 | 207 | return true; |
208 | - }else{ |
|
208 | + }else { |
|
209 | 209 | exit; |
210 | 210 | return false; |
211 | 211 | } |
212 | 212 | } |
213 | 213 | |
214 | - protected function processSheet($file){ |
|
214 | + protected function processSheet($file) { |
|
215 | 215 | $this->startTime = Carbon::now()->tz('Asia/Colombo'); |
216 | 216 | $user = User::find($file['security_user_id']); |
217 | 217 | $this->checkNode($file); |
@@ -219,39 +219,39 @@ discard block |
||
219 | 219 | $this->output->writeln('Processing the file: '.$file['filename']); |
220 | 220 | if ($this->checkTime()) { |
221 | 221 | try { |
222 | - $this->import($file,1,'C'); |
|
222 | + $this->import($file, 1, 'C'); |
|
223 | 223 | sleep(10); |
224 | - $this->import($file,2,'B'); |
|
224 | + $this->import($file, 2, 'B'); |
|
225 | 225 | |
226 | - } catch (\Maatwebsite\Excel\Validators\ValidationException $e) { |
|
227 | - $this->output->writeln( $e->getMessage()); |
|
226 | + }catch (\Maatwebsite\Excel\Validators\ValidationException $e) { |
|
227 | + $this->output->writeln($e->getMessage()); |
|
228 | 228 | try { |
229 | 229 | Mail::to($user->email)->send(new IncorrectTemplate($file)); |
230 | 230 | DB::table('uploads') |
231 | 231 | ->where('id', $file['id']) |
232 | - ->update(['is_processed' => 2, 'is_email_sent' => 1,'updated_at' => now()]); |
|
233 | - } catch (\Exception $ex) { |
|
234 | - $this->output->writeln( $e->getMessage()); |
|
232 | + ->update(['is_processed' => 2, 'is_email_sent' => 1, 'updated_at' => now()]); |
|
233 | + }catch (\Exception $ex) { |
|
234 | + $this->output->writeln($e->getMessage()); |
|
235 | 235 | $this->handle(); |
236 | 236 | DB::table('uploads') |
237 | 237 | ->where('id', $file['id']) |
238 | - ->update(['is_processed' => 2, 'is_email_sent' => 2 ,'updated_at' => now()]); |
|
238 | + ->update(['is_processed' => 2, 'is_email_sent' => 2, 'updated_at' => now()]); |
|
239 | 239 | } |
240 | 240 | } |
241 | - } else { |
|
241 | + }else { |
|
242 | 242 | exit(); |
243 | 243 | } |
244 | 244 | } |
245 | 245 | |
246 | - protected function getType($file){ |
|
247 | - $file = storage_path() . '/app/sis-bulk-data-files/'.$file; |
|
248 | - $inputFileType = \PhpOffice\PhpSpreadsheet\IOFactory::identify($file); |
|
246 | + protected function getType($file) { |
|
247 | + $file = storage_path().'/app/sis-bulk-data-files/'.$file; |
|
248 | + $inputFileType = \PhpOffice\PhpSpreadsheet\IOFactory::identify($file); |
|
249 | 249 | return $inputFileType; |
250 | 250 | } |
251 | 251 | |
252 | 252 | |
253 | - protected function getSheetWriter($file,$reader){ |
|
254 | - switch ($this->getType($file['filename'])){ |
|
253 | + protected function getSheetWriter($file, $reader) { |
|
254 | + switch ($this->getType($file['filename'])) { |
|
255 | 255 | case 'Xlsx': |
256 | 256 | return new \PhpOffice\PhpSpreadsheet\Writer\Xlsx($reader); |
257 | 257 | break; |
@@ -267,8 +267,8 @@ discard block |
||
267 | 267 | } |
268 | 268 | } |
269 | 269 | |
270 | - protected function getSheetType($file){ |
|
271 | - switch ($this->getType($file)){ |
|
270 | + protected function getSheetType($file) { |
|
271 | + switch ($this->getType($file)) { |
|
272 | 272 | case 'Xlsx': |
273 | 273 | return \Maatwebsite\Excel\Excel::XLSX; |
274 | 274 | break; |
@@ -285,7 +285,7 @@ discard block |
||
285 | 285 | } |
286 | 286 | |
287 | 287 | |
288 | - protected function getSheetCount($file){ |
|
288 | + protected function getSheetCount($file) { |
|
289 | 289 | $objPHPExcel = $this->setReader($file); |
290 | 290 | return $objPHPExcel->getSheetCount(); |
291 | 291 | } |
@@ -297,205 +297,205 @@ discard block |
||
297 | 297 | * @param $sheet |
298 | 298 | * @param $column |
299 | 299 | */ |
300 | - protected function import($file, $sheet, $column){ |
|
300 | + protected function import($file, $sheet, $column) { |
|
301 | 301 | try { |
302 | 302 | ini_set('memory_limit', '2048M'); |
303 | 303 | $this->getFileSize($file); |
304 | 304 | $user = User::find($file['security_user_id']); |
305 | - $excelFile = '/sis-bulk-data-files/' . $file['filename']; |
|
306 | - $this->higestRow = $this->getHigestRow($file, $sheet,$column); |
|
307 | - switch ($sheet){ |
|
305 | + $excelFile = '/sis-bulk-data-files/'.$file['filename']; |
|
306 | + $this->higestRow = $this->getHigestRow($file, $sheet, $column); |
|
307 | + switch ($sheet) { |
|
308 | 308 | case 1; |
309 | - $this->output->writeln( 'Trying to insert Students'); |
|
310 | - if (($this->getSheetName($file,'Insert Students')) && $this->higestRow > 0) { // |
|
309 | + $this->output->writeln('Trying to insert Students'); |
|
310 | + if (($this->getSheetName($file, 'Insert Students')) && $this->higestRow > 0) { // |
|
311 | 311 | $import = new UsersImport($file); |
312 | - $import->import($excelFile,'local',$this->getSheetType($file['filename'])); |
|
312 | + $import->import($excelFile, 'local', $this->getSheetType($file['filename'])); |
|
313 | 313 | // Excel::import($import, $excelFile, 'local'); |
314 | 314 | DB::table('uploads') |
315 | 315 | ->where('id', $file['id']) |
316 | - ->update(['insert' => 1,'is_processed' => 1,'updated_at' => now()]); |
|
317 | - if($import->failures()->count() > 0){ |
|
318 | - self::writeErrors($import,$file,'Insert Students'); |
|
316 | + ->update(['insert' => 1, 'is_processed' => 1, 'updated_at' => now()]); |
|
317 | + if ($import->failures()->count() > 0) { |
|
318 | + self::writeErrors($import, $file, 'Insert Students'); |
|
319 | 319 | DB::table('uploads') |
320 | 320 | ->where('id', $file['id']) |
321 | - ->update(['insert' => 3,'updated_at' => now()]); |
|
322 | - $this->processFailedEmail($file,$user,'Fresh Student Data Upload:Partial Success '); |
|
323 | - $this->stdOut('Insert Students',$this->higestRow); |
|
324 | - }else{ |
|
325 | - $this->processSuccessEmail($file,$user,'Fresh Student Data Upload:Success '); |
|
326 | - $this->stdOut('Insert Students',$this->higestRow); |
|
321 | + ->update(['insert' => 3, 'updated_at' => now()]); |
|
322 | + $this->processFailedEmail($file, $user, 'Fresh Student Data Upload:Partial Success '); |
|
323 | + $this->stdOut('Insert Students', $this->higestRow); |
|
324 | + }else { |
|
325 | + $this->processSuccessEmail($file, $user, 'Fresh Student Data Upload:Success '); |
|
326 | + $this->stdOut('Insert Students', $this->higestRow); |
|
327 | 327 | } |
328 | - }else if(($this->getSheetName($file,'Insert Students')) && $this->higestRow > 0) { |
|
328 | + }else if (($this->getSheetName($file, 'Insert Students')) && $this->higestRow > 0) { |
|
329 | 329 | DB::table('uploads') |
330 | 330 | ->where('id', $file['id']) |
331 | 331 | ->update(['is_processed' => 2]); |
332 | - $this->processEmptyEmail($file,$user, 'Fresh Student Data Upload '); |
|
332 | + $this->processEmptyEmail($file, $user, 'Fresh Student Data Upload '); |
|
333 | 333 | } |
334 | 334 | break; |
335 | 335 | case 2; |
336 | - $this->output->writeln( 'Trying to update Students'); |
|
337 | - if (($this->getSheetName($file,'Update Students')) && $this->higestRow > 0) { |
|
336 | + $this->output->writeln('Trying to update Students'); |
|
337 | + if (($this->getSheetName($file, 'Update Students')) && $this->higestRow > 0) { |
|
338 | 338 | $import = new StudentUpdate($file); |
339 | - $import->import($excelFile,'local',$this->getSheetType($file['filename'])); |
|
339 | + $import->import($excelFile, 'local', $this->getSheetType($file['filename'])); |
|
340 | 340 | DB::table('uploads') |
341 | 341 | ->where('id', $file['id']) |
342 | - ->update(['update' => 1,'is_processed' => 1,'updated_at' => now()]); |
|
343 | - if($import->failures()->count() > 0){ |
|
344 | - self::writeErrors($import,$file,'Update Students'); |
|
342 | + ->update(['update' => 1, 'is_processed' => 1, 'updated_at' => now()]); |
|
343 | + if ($import->failures()->count() > 0) { |
|
344 | + self::writeErrors($import, $file, 'Update Students'); |
|
345 | 345 | DB::table('uploads') |
346 | 346 | ->where('id', $file['id']) |
347 | - ->update(['update' => 3,'is_processed' => 1,'updated_at' => now()]); |
|
348 | - $this->processFailedEmail($file,$user,'Existing Student Data Update:Partial Success '); |
|
349 | - $this->stdOut('Update Students',$this->higestRow); |
|
350 | - }else{ |
|
351 | - $this->processSuccessEmail($file,$user, 'Existing Student Data Update:Success '); |
|
352 | - $this->stdOut('Update Students',$this->higestRow); |
|
347 | + ->update(['update' => 3, 'is_processed' => 1, 'updated_at' => now()]); |
|
348 | + $this->processFailedEmail($file, $user, 'Existing Student Data Update:Partial Success '); |
|
349 | + $this->stdOut('Update Students', $this->higestRow); |
|
350 | + }else { |
|
351 | + $this->processSuccessEmail($file, $user, 'Existing Student Data Update:Success '); |
|
352 | + $this->stdOut('Update Students', $this->higestRow); |
|
353 | 353 | } |
354 | - }else if(($this->getSheetName($file,'Update Students')) && $this->higestRow == 0) { |
|
354 | + }else if (($this->getSheetName($file, 'Update Students')) && $this->higestRow == 0) { |
|
355 | 355 | DB::table('uploads') |
356 | 356 | ->where('id', $file['id']) |
357 | - ->update(['is_processed' => 2,'updated_at' => now()]); |
|
358 | - $this->processEmptyEmail($file,$user, 'Existing Student Data Update'); |
|
357 | + ->update(['is_processed' => 2, 'updated_at' => now()]); |
|
358 | + $this->processEmptyEmail($file, $user, 'Existing Student Data Update'); |
|
359 | 359 | } |
360 | 360 | break; |
361 | 361 | } |
362 | 362 | }catch (\Maatwebsite\Excel\Validators\ValidationException $e) { |
363 | - $this->output->writeln( $e->getMessage()); |
|
364 | - if($sheet == 1){ |
|
365 | - self::writeErrors($e,$file,'Insert Students'); |
|
363 | + $this->output->writeln($e->getMessage()); |
|
364 | + if ($sheet == 1) { |
|
365 | + self::writeErrors($e, $file, 'Insert Students'); |
|
366 | 366 | DB::table('uploads') |
367 | 367 | ->where('id', $file['id']) |
368 | - ->update(['insert' => 2,'updated_at' => now()]); |
|
369 | - $this->processFailedEmail($file,$user,'Fresh Student Data Upload:Failed'); |
|
370 | - }else if($sheet == 2){ |
|
371 | - self::writeErrors($e,$file,'Update Students'); |
|
368 | + ->update(['insert' => 2, 'updated_at' => now()]); |
|
369 | + $this->processFailedEmail($file, $user, 'Fresh Student Data Upload:Failed'); |
|
370 | + }else if ($sheet == 2) { |
|
371 | + self::writeErrors($e, $file, 'Update Students'); |
|
372 | 372 | DB::table('uploads') |
373 | 373 | ->where('id', $file['id']) |
374 | - ->update(['update' => 2,'updated_at' => now()]); |
|
375 | - $this->processFailedEmail($file,$user, 'Existing Student Data Update:Failed'); |
|
374 | + ->update(['update' => 2, 'updated_at' => now()]); |
|
375 | + $this->processFailedEmail($file, $user, 'Existing Student Data Update:Failed'); |
|
376 | 376 | } |
377 | 377 | DB::table('uploads') |
378 | - ->where('id', $file['id']) |
|
379 | - ->update(['is_processed' =>2 , 'updated_at' => now()]); |
|
378 | + ->where('id', $file['id']) |
|
379 | + ->update(['is_processed' =>2, 'updated_at' => now()]); |
|
380 | 380 | |
381 | 381 | } |
382 | 382 | |
383 | 383 | } |
384 | 384 | |
385 | - protected function processErrors($failure){ |
|
386 | - $error_mesg = implode(',',$failure->errors()); |
|
385 | + protected function processErrors($failure) { |
|
386 | + $error_mesg = implode(',', $failure->errors()); |
|
387 | 387 | $failure = [ |
388 | 388 | 'row'=> $failure->row(), |
389 | - 'errors' => [ $error_mesg], |
|
389 | + 'errors' => [$error_mesg], |
|
390 | 390 | 'attribute' => $failure->attribute() |
391 | 391 | ]; |
392 | 392 | return $failure; |
393 | 393 | |
394 | 394 | } |
395 | 395 | |
396 | - protected function getFileSize($file){ |
|
397 | - $excelFile = '/sis-bulk-data-files/' . $file['filename']; |
|
396 | + protected function getFileSize($file) { |
|
397 | + $excelFile = '/sis-bulk-data-files/'.$file['filename']; |
|
398 | 398 | $size = Storage::disk('local')->size($excelFile); |
399 | 399 | $user = User::find($file['security_user_id']); |
400 | - if( $size > 0){ |
|
400 | + if ($size > 0) { |
|
401 | 401 | return true; |
402 | - }else{ |
|
402 | + }else { |
|
403 | 403 | DB::table('uploads') |
404 | - ->where('id', $file['id']) |
|
405 | - ->update(['is_processed' =>2 , 'updated_at' => now()]); |
|
406 | - $this->stdOut('No valid data found :Please re-upload the file',0); |
|
407 | - $this->processEmptyEmail($file,$user, 'No valid data found :Please re-upload the file'); |
|
404 | + ->where('id', $file['id']) |
|
405 | + ->update(['is_processed' =>2, 'updated_at' => now()]); |
|
406 | + $this->stdOut('No valid data found :Please re-upload the file', 0); |
|
407 | + $this->processEmptyEmail($file, $user, 'No valid data found :Please re-upload the file'); |
|
408 | 408 | } |
409 | 409 | } |
410 | 410 | |
411 | - protected function setReader($file){ |
|
412 | - try{ |
|
413 | - $excelFile = '/sis-bulk-data-files/processed/' . $file['filename']; |
|
411 | + protected function setReader($file) { |
|
412 | + try { |
|
413 | + $excelFile = '/sis-bulk-data-files/processed/'.$file['filename']; |
|
414 | 414 | $exists = Storage::disk('local')->exists($excelFile); |
415 | - if(!$exists){ |
|
415 | + if (!$exists) { |
|
416 | 416 | |
417 | - $excelFile = "/sis-bulk-data-files/" . $file['filename']; |
|
417 | + $excelFile = "/sis-bulk-data-files/".$file['filename']; |
|
418 | 418 | } |
419 | - $excelFile = storage_path()."/app" . $excelFile; |
|
419 | + $excelFile = storage_path()."/app".$excelFile; |
|
420 | 420 | $reader = \PhpOffice\PhpSpreadsheet\IOFactory::createReader($this->getType($file['filename'])); |
421 | - $objPHPExcel = $reader->load($excelFile); |
|
421 | + $objPHPExcel = $reader->load($excelFile); |
|
422 | 422 | return $objPHPExcel; |
423 | - }catch (Exception $e){ |
|
424 | - $this->output->writeln( $e->getMessage()); |
|
423 | + }catch (Exception $e) { |
|
424 | + $this->output->writeln($e->getMessage()); |
|
425 | 425 | $user = User::find($file['security_user_id']); |
426 | 426 | DB::table('uploads') |
427 | - ->where('id', $file['id']) |
|
428 | - ->update(['is_processed' =>2 , 'updated_at' => now()]); |
|
429 | - $this->stdOut('No valid data found :Please re-upload the file',0); |
|
430 | - $this->processEmptyEmail($file,$user, 'No valid data found :Please re-upload the file'); |
|
427 | + ->where('id', $file['id']) |
|
428 | + ->update(['is_processed' =>2, 'updated_at' => now()]); |
|
429 | + $this->stdOut('No valid data found :Please re-upload the file', 0); |
|
430 | + $this->processEmptyEmail($file, $user, 'No valid data found :Please re-upload the file'); |
|
431 | 431 | } |
432 | 432 | } |
433 | 433 | |
434 | - protected function getSheetName($file,$sheet){ |
|
435 | - try{; |
|
434 | + protected function getSheetName($file, $sheet) { |
|
435 | + try {; |
|
436 | 436 | $objPHPExcel = $this->setReader($file); |
437 | - return $objPHPExcel->getSheetByName($sheet) !== null; |
|
438 | - }catch (Exception $e){ |
|
439 | - $this->output->writeln( $e->getMessage()); |
|
437 | + return $objPHPExcel->getSheetByName($sheet) !== null; |
|
438 | + }catch (Exception $e) { |
|
439 | + $this->output->writeln($e->getMessage()); |
|
440 | 440 | $user = User::find($file['security_user_id']); |
441 | 441 | DB::table('uploads') |
442 | - ->where('id', $file['id']) |
|
443 | - ->update(['is_processed' =>2 , 'updated_at' => now()]); |
|
444 | - $this->stdOut('No valid data found :Please re-upload the file',0); |
|
445 | - $this->processEmptyEmail($file,$user, 'No valid data found :Please re-upload the file'); |
|
442 | + ->where('id', $file['id']) |
|
443 | + ->update(['is_processed' =>2, 'updated_at' => now()]); |
|
444 | + $this->stdOut('No valid data found :Please re-upload the file', 0); |
|
445 | + $this->processEmptyEmail($file, $user, 'No valid data found :Please re-upload the file'); |
|
446 | 446 | } |
447 | 447 | } |
448 | 448 | |
449 | - protected function getHigestRow($file,$sheet,$column){ |
|
450 | - try{ |
|
449 | + protected function getHigestRow($file, $sheet, $column) { |
|
450 | + try { |
|
451 | 451 | $reader = $this->setReader($file); |
452 | 452 | $reader->setActiveSheetIndex($sheet); |
453 | 453 | $higestRow = 0; |
454 | - $highestRow = $reader->getActiveSheet()->getHighestRow($column); |
|
454 | + $highestRow = $reader->getActiveSheet()->getHighestRow($column); |
|
455 | 455 | for ($row = 3; $row <= $highestRow; $row++) { |
456 | 456 | $rowData = $reader->getActiveSheet()->getCell($column.$row)->getValue(); |
457 | 457 | if (empty($rowData) || $rowData == null) { |
458 | 458 | continue; |
459 | - } else { |
|
459 | + }else { |
|
460 | 460 | $higestRow += 1; |
461 | 461 | } |
462 | 462 | } |
463 | 463 | return $higestRow; |
464 | - }catch(\Exception $e){ |
|
465 | - $this->output->writeln( $e->getMessage()); |
|
464 | + }catch (\Exception $e) { |
|
465 | + $this->output->writeln($e->getMessage()); |
|
466 | 466 | $user = User::find($file['security_user_id']); |
467 | 467 | DB::beginTransaction(); |
468 | 468 | DB::table('uploads') |
469 | 469 | ->where('id', $file['id']) |
470 | - ->update(['is_processed' => 2,'updated_at' => now()]); |
|
470 | + ->update(['is_processed' => 2, 'updated_at' => now()]); |
|
471 | 471 | DB::commit(); |
472 | - $this->processEmptyEmail($file,$user, 'No valid data found'); |
|
472 | + $this->processEmptyEmail($file, $user, 'No valid data found'); |
|
473 | 473 | exit(); |
474 | 474 | } |
475 | 475 | } |
476 | 476 | |
477 | - protected function stdOut($title,$rows){ |
|
478 | - $this->output->writeln( $title. ' Process completed at . '.' '. now()); |
|
477 | + protected function stdOut($title, $rows) { |
|
478 | + $this->output->writeln($title.' Process completed at . '.' '.now()); |
|
479 | 479 | $now = Carbon::now()->tz('Asia/Colombo'); |
480 | - $this->output->writeln('Total Processed lines: ' . $rows); |
|
481 | - $this->output->writeln( 'Time taken to process : '. $now->diffInSeconds($this->startTime) .' Seconds'); |
|
480 | + $this->output->writeln('Total Processed lines: '.$rows); |
|
481 | + $this->output->writeln('Time taken to process : '.$now->diffInSeconds($this->startTime).' Seconds'); |
|
482 | 482 | $this->output->writeln('--------------------------------------------------------------------------------------------------------------------------'); |
483 | 483 | } |
484 | 484 | |
485 | 485 | |
486 | 486 | |
487 | - protected function removeRows($row,$count,$params){ |
|
487 | + protected function removeRows($row, $count, $params) { |
|
488 | 488 | $reader = $params['reader']; |
489 | 489 | $sheet = $reader->getActiveSheet(); |
490 | - if(!in_array($row,$params['rows'])){ |
|
490 | + if (!in_array($row, $params['rows'])) { |
|
491 | 491 | $output = new \Symfony\Component\Console\Output\ConsoleOutput(); |
492 | - $this->output->writeln( ' removing row . '.' '. $row); |
|
492 | + $this->output->writeln(' removing row . '.' '.$row); |
|
493 | 493 | $reader->getActiveSheet()->getCellCollection()->removeRow($row); |
494 | 494 | } |
495 | 495 | } |
496 | 496 | |
497 | 497 | |
498 | - protected function writeErrors($e,$file,$sheet){ |
|
498 | + protected function writeErrors($e, $file, $sheet) { |
|
499 | 499 | try { |
500 | 500 | ini_set('memory_limit', '2048M'); |
501 | 501 | $baseMemory = memory_get_usage(); |
@@ -510,39 +510,39 @@ discard block |
||
510 | 510 | $reader = $this->setReader($file); |
511 | 511 | $reader->setActiveSheetIndexByName($sheet); |
512 | 512 | |
513 | - $failures = gettype($failures) == 'object' ? array_map(array($this,'processErrors'),iterator_to_array($failures)) : array_map(array($this,'processErrors'),($failures)); |
|
514 | - if(count($failures) > 0){ |
|
515 | - $rows = array_map('rows',$failures); |
|
513 | + $failures = gettype($failures) == 'object' ? array_map(array($this, 'processErrors'), iterator_to_array($failures)) : array_map(array($this, 'processErrors'), ($failures)); |
|
514 | + if (count($failures) > 0) { |
|
515 | + $rows = array_map('rows', $failures); |
|
516 | 516 | $rows = array_unique($rows); |
517 | - $rowIndex = range(3,$this->higestRow+2); |
|
517 | + $rowIndex = range(3, $this->higestRow + 2); |
|
518 | 518 | $params = [ |
519 | 519 | 'rows' =>$rows, |
520 | 520 | 'reader' => $reader |
521 | 521 | ]; |
522 | - array_walk($failures , 'append_errors_to_excel',$reader); |
|
523 | - array_walk($rowIndex , array($this,'removeRows'),$params); |
|
524 | - $objWriter = $this->getSheetWriter($file,$reader); |
|
522 | + array_walk($failures, 'append_errors_to_excel', $reader); |
|
523 | + array_walk($rowIndex, array($this, 'removeRows'), $params); |
|
524 | + $objWriter = $this->getSheetWriter($file, $reader); |
|
525 | 525 | Storage::disk('local')->makeDirectory('sis-bulk-data-files/processed'); |
526 | - $objWriter->save(storage_path() . '/app/sis-bulk-data-files/processed/' . $file['filename']); |
|
526 | + $objWriter->save(storage_path().'/app/sis-bulk-data-files/processed/'.$file['filename']); |
|
527 | 527 | $now = Carbon::now()->tz('Asia/Colombo'); |
528 | - $this->output->writeln( $reader->getActiveSheet()->getTitle() . ' Process completed at . '.' '. now()); |
|
528 | + $this->output->writeln($reader->getActiveSheet()->getTitle().' Process completed at . '.' '.now()); |
|
529 | 529 | $this->output->writeln('memory usage for the processes : '.(memory_get_usage() - $baseMemory)); |
530 | - $this->output->writeln( 'Time taken to process : '. $now->diffInSeconds($this->startTime) .' Seconds'); |
|
530 | + $this->output->writeln('Time taken to process : '.$now->diffInSeconds($this->startTime).' Seconds'); |
|
531 | 531 | $this->output->writeln(' errors reported : '.count($failures)); |
532 | 532 | $this->output->writeln('--------------------------------------------------------------------------------------------------------------------------'); |
533 | 533 | unset($objWriter); |
534 | 534 | unset($failures); |
535 | 535 | } |
536 | 536 | |
537 | - }catch (Eception $e){ |
|
538 | - $this->output->writeln( $e->getMessage()); |
|
537 | + }catch (Eception $e) { |
|
538 | + $this->output->writeln($e->getMessage()); |
|
539 | 539 | $user = User::find($file['security_user_id']); |
540 | 540 | DB::beginTransaction(); |
541 | 541 | DB::table('uploads') |
542 | 542 | ->where('id', $file['id']) |
543 | - ->update(['is_processed' => 2,'updated_at' => now()]); |
|
543 | + ->update(['is_processed' => 2, 'updated_at' => now()]); |
|
544 | 544 | DB::commit(); |
545 | - $this->processEmptyEmail($file,$user, 'No valid data found'); |
|
545 | + $this->processEmptyEmail($file, $user, 'No valid data found'); |
|
546 | 546 | exit(); |
547 | 547 | } |
548 | 548 | } |
@@ -70,21 +70,21 @@ discard block |
||
70 | 70 | unset($files); |
71 | 71 | exit(); |
72 | 72 | |
73 | - }else{ |
|
73 | + } else{ |
|
74 | 74 | $output = new \Symfony\Component\Console\Output\ConsoleOutput(); |
75 | 75 | $this->output->writeln('No files found,Waiting for files'); |
76 | 76 | exit(); |
77 | 77 | |
78 | 78 | } |
79 | 79 | |
80 | - }catch (Exception $e){ |
|
80 | + } catch (Exception $e){ |
|
81 | 81 | $output = new \Symfony\Component\Console\Output\ConsoleOutput(); |
82 | 82 | $this->output->writeln($e); |
83 | 83 | sleep(300); |
84 | 84 | $this->handle(); |
85 | 85 | |
86 | 86 | } |
87 | - }else{ |
|
87 | + } else{ |
|
88 | 88 | exit(); |
89 | 89 | } |
90 | 90 | } |
@@ -205,7 +205,7 @@ discard block |
||
205 | 205 | $output = new \Symfony\Component\Console\Output\ConsoleOutput(); |
206 | 206 | $this->output->writeln('Processing from:' . $node); |
207 | 207 | return true; |
208 | - }else{ |
|
208 | + } else{ |
|
209 | 209 | exit; |
210 | 210 | return false; |
211 | 211 | } |
@@ -321,11 +321,11 @@ discard block |
||
321 | 321 | ->update(['insert' => 3,'updated_at' => now()]); |
322 | 322 | $this->processFailedEmail($file,$user,'Fresh Student Data Upload:Partial Success '); |
323 | 323 | $this->stdOut('Insert Students',$this->higestRow); |
324 | - }else{ |
|
324 | + } else{ |
|
325 | 325 | $this->processSuccessEmail($file,$user,'Fresh Student Data Upload:Success '); |
326 | 326 | $this->stdOut('Insert Students',$this->higestRow); |
327 | 327 | } |
328 | - }else if(($this->getSheetName($file,'Insert Students')) && $this->higestRow > 0) { |
|
328 | + } else if(($this->getSheetName($file,'Insert Students')) && $this->higestRow > 0) { |
|
329 | 329 | DB::table('uploads') |
330 | 330 | ->where('id', $file['id']) |
331 | 331 | ->update(['is_processed' => 2]); |
@@ -347,11 +347,11 @@ discard block |
||
347 | 347 | ->update(['update' => 3,'is_processed' => 1,'updated_at' => now()]); |
348 | 348 | $this->processFailedEmail($file,$user,'Existing Student Data Update:Partial Success '); |
349 | 349 | $this->stdOut('Update Students',$this->higestRow); |
350 | - }else{ |
|
350 | + } else{ |
|
351 | 351 | $this->processSuccessEmail($file,$user, 'Existing Student Data Update:Success '); |
352 | 352 | $this->stdOut('Update Students',$this->higestRow); |
353 | 353 | } |
354 | - }else if(($this->getSheetName($file,'Update Students')) && $this->higestRow == 0) { |
|
354 | + } else if(($this->getSheetName($file,'Update Students')) && $this->higestRow == 0) { |
|
355 | 355 | DB::table('uploads') |
356 | 356 | ->where('id', $file['id']) |
357 | 357 | ->update(['is_processed' => 2,'updated_at' => now()]); |
@@ -359,7 +359,7 @@ discard block |
||
359 | 359 | } |
360 | 360 | break; |
361 | 361 | } |
362 | - }catch (\Maatwebsite\Excel\Validators\ValidationException $e) { |
|
362 | + } catch (\Maatwebsite\Excel\Validators\ValidationException $e) { |
|
363 | 363 | $this->output->writeln( $e->getMessage()); |
364 | 364 | if($sheet == 1){ |
365 | 365 | self::writeErrors($e,$file,'Insert Students'); |
@@ -367,7 +367,7 @@ discard block |
||
367 | 367 | ->where('id', $file['id']) |
368 | 368 | ->update(['insert' => 2,'updated_at' => now()]); |
369 | 369 | $this->processFailedEmail($file,$user,'Fresh Student Data Upload:Failed'); |
370 | - }else if($sheet == 2){ |
|
370 | + } else if($sheet == 2){ |
|
371 | 371 | self::writeErrors($e,$file,'Update Students'); |
372 | 372 | DB::table('uploads') |
373 | 373 | ->where('id', $file['id']) |
@@ -399,7 +399,7 @@ discard block |
||
399 | 399 | $user = User::find($file['security_user_id']); |
400 | 400 | if( $size > 0){ |
401 | 401 | return true; |
402 | - }else{ |
|
402 | + } else{ |
|
403 | 403 | DB::table('uploads') |
404 | 404 | ->where('id', $file['id']) |
405 | 405 | ->update(['is_processed' =>2 , 'updated_at' => now()]); |
@@ -420,7 +420,7 @@ discard block |
||
420 | 420 | $reader = \PhpOffice\PhpSpreadsheet\IOFactory::createReader($this->getType($file['filename'])); |
421 | 421 | $objPHPExcel = $reader->load($excelFile); |
422 | 422 | return $objPHPExcel; |
423 | - }catch (Exception $e){ |
|
423 | + } catch (Exception $e){ |
|
424 | 424 | $this->output->writeln( $e->getMessage()); |
425 | 425 | $user = User::find($file['security_user_id']); |
426 | 426 | DB::table('uploads') |
@@ -435,7 +435,7 @@ discard block |
||
435 | 435 | try{; |
436 | 436 | $objPHPExcel = $this->setReader($file); |
437 | 437 | return $objPHPExcel->getSheetByName($sheet) !== null; |
438 | - }catch (Exception $e){ |
|
438 | + } catch (Exception $e){ |
|
439 | 439 | $this->output->writeln( $e->getMessage()); |
440 | 440 | $user = User::find($file['security_user_id']); |
441 | 441 | DB::table('uploads') |
@@ -461,7 +461,7 @@ discard block |
||
461 | 461 | } |
462 | 462 | } |
463 | 463 | return $higestRow; |
464 | - }catch(\Exception $e){ |
|
464 | + } catch(\Exception $e){ |
|
465 | 465 | $this->output->writeln( $e->getMessage()); |
466 | 466 | $user = User::find($file['security_user_id']); |
467 | 467 | DB::beginTransaction(); |
@@ -534,7 +534,7 @@ discard block |
||
534 | 534 | unset($failures); |
535 | 535 | } |
536 | 536 | |
537 | - }catch (Eception $e){ |
|
537 | + } catch (Eception $e){ |
|
538 | 538 | $this->output->writeln( $e->getMessage()); |
539 | 539 | $user = User::find($file['security_user_id']); |
540 | 540 | DB::beginTransaction(); |
@@ -41,6 +41,6 @@ |
||
41 | 41 | { |
42 | 42 | $year = $this->argument('year'); |
43 | 43 | $institution = $this->instituion_grade->getInstitutionGradeList($year); |
44 | - $this->call('promote:students',['year' => $year,'institution' => $institution->code]); |
|
44 | + $this->call('promote:students', ['year' => $year, 'institution' => $institution->code]); |
|
45 | 45 | } |
46 | 46 | } |
@@ -25,8 +25,8 @@ |
||
25 | 25 | */ |
26 | 26 | protected function schedule(Schedule $schedule) |
27 | 27 | { |
28 | - $schedule->command('import:students') |
|
29 | - ->cron('* * * * * '); |
|
28 | + $schedule->command('import:students') |
|
29 | + ->cron('* * * * * '); |
|
30 | 30 | } |
31 | 31 | |
32 | 32 | /** |
@@ -31,12 +31,12 @@ discard block |
||
31 | 31 | public function __construct($class) { |
32 | 32 | |
33 | 33 | $this->class = $class; |
34 | - $this->_file_name = time() . '_' . Auth::user()->id . '_' . 'student_upload.xls'; |
|
34 | + $this->_file_name = time().'_'.Auth::user()->id.'_'.'student_upload.xls'; |
|
35 | 35 | } |
36 | 36 | |
37 | 37 | public function registerEvents(): array { |
38 | 38 | return [ |
39 | - BeforeSheet::class => function(BeforeSheet $event){ |
|
39 | + BeforeSheet::class => function(BeforeSheet $event) { |
|
40 | 40 | // dd($event->crea) |
41 | 41 | }, |
42 | 42 | BeforeWriting::class => function(BeforeWriting $event) { |
@@ -63,7 +63,7 @@ discard block |
||
63 | 63 | $class = $this->class; |
64 | 64 | return Security_user::select('openemis_no', 'first_name', 'gender_id', 'date_of_birth', 'address', 'birthplace_area_id') |
65 | 65 | ->with(['class', 'special_needs']) |
66 | - ->whereHas('class', function ($query) use ($class) { |
|
66 | + ->whereHas('class', function($query) use ($class) { |
|
67 | 67 | $query->where('institution_class_id', '=', $class); |
68 | 68 | }) |
69 | 69 | ->get(); |
@@ -4,7 +4,7 @@ |
||
4 | 4 | |
5 | 5 | use Illuminate\Database\Eloquent\Model; |
6 | 6 | |
7 | -class User_body_mass extends Base_Model { |
|
7 | +class User_body_mass extends Base_Model { |
|
8 | 8 | |
9 | 9 | /** |
10 | 10 | * The database table used by the model. |
@@ -4,7 +4,7 @@ discard block |
||
4 | 4 | |
5 | 5 | use Illuminate\Database\Eloquent\Model; |
6 | 6 | |
7 | -class Institution_staff extends Model { |
|
7 | +class Institution_staff extends Model { |
|
8 | 8 | |
9 | 9 | /** |
10 | 10 | * The database table used by the model. |
@@ -42,12 +42,12 @@ discard block |
||
42 | 42 | protected $dates = ['start_date', 'end_date', 'modified', 'created']; |
43 | 43 | |
44 | 44 | |
45 | - public function staff_class(){ |
|
46 | - return $this->hasMany('App\Models\Institution_class','staff_id','staff_id'); |
|
45 | + public function staff_class() { |
|
46 | + return $this->hasMany('App\Models\Institution_class', 'staff_id', 'staff_id'); |
|
47 | 47 | } |
48 | 48 | |
49 | - public function institution(){ |
|
50 | - return $this->belongsTo('App\Models\Institution','institution_id'); |
|
49 | + public function institution() { |
|
50 | + return $this->belongsTo('App\Models\Institution', 'institution_id'); |
|
51 | 51 | } |
52 | 52 | |
53 | 53 |
@@ -4,7 +4,7 @@ |
||
4 | 4 | |
5 | 5 | use Illuminate\Database\Eloquent\Model; |
6 | 6 | |
7 | -class Nationality extends Model { |
|
7 | +class Nationality extends Model { |
|
8 | 8 | |
9 | 9 | /** |
10 | 10 | * The database table used by the model. |