Proyectos de Subversion LeadersLinked - Backend

Rev

Rev 17000 | Ir a la última revisión | | Comparar con el anterior | Ultima modificación | Ver Log |

Rev Autor Línea Nro. Línea
1 www 1
<?php
2
declare(strict_types=1);
3
 
4
namespace LeadersLinked\Controller;
5
 
6
use Laminas\Db\Adapter\AdapterInterface;
16768 efrain 7
 
1 www 8
use Laminas\Mvc\Controller\AbstractActionController;
9
use Laminas\Log\LoggerInterface;
10
use Laminas\View\Model\ViewModel;
11
use Laminas\View\Model\JsonModel;
12
use LeadersLinked\Mapper\CompanyMicrolearningTopicMapper;
13
use LeadersLinked\Mapper\CompanyMicrolearningCapsuleMapper;
14
use LeadersLinked\Form\TopicCapsuleForm;
15
use LeadersLinked\Form\PushMicrolearningNotificationForm;
16
use LeadersLinked\Mapper\QueryMapper;
17
use LeadersLinked\Mapper\CompanyMicrolearningCapsuleUserMapper;
18
use LeadersLinked\Mapper\UserMapper;
19
use Laminas\Hydrator\ArraySerializableHydrator;
20
use Laminas\Db\ResultSet\HydratingResultSet;
21
use Laminas\Paginator\Adapter\DbSelect;
22
use Laminas\Paginator\Paginator;
23
use LeadersLinked\Model\CompanyMicrolearningCapsuleUser;
24
use LeadersLinked\Mapper\ApplicationMapper;
25
use LeadersLinked\Mapper\PushMapper;
26
use LeadersLinked\Mapper\PushTemplateMapper;
27
use LeadersLinked\Mapper\DeviceHistoryMapper;
28
use LeadersLinked\Model\Push;
29
use LeadersLinked\Model\Application;
30
use LeadersLinked\Form\CapsuleCustomerUploadForm;
31
use PhpOffice\PhpSpreadsheet\IOFactory;
32
use LeadersLinked\Model\User;
33
use LeadersLinked\Model\UserType;
34
use LeadersLinked\Model\UserPassword;
35
use LeadersLinked\Mapper\CompanyMicrolearningUserMapper;
36
use LeadersLinked\Mapper\UserPasswordMapper;
37
use LeadersLinked\Mapper\CompanyMicrolearningExtendUserMapper;
38
use LeadersLinked\Mapper\CompanyMicrolearningExtendUserCompanyMapper;
39
use LeadersLinked\Mapper\CompanyMicrolearningExtendUserFunctionMapper;
40
use LeadersLinked\Mapper\CompanyMicrolearningExtendUserGroupMapper;
41
use LeadersLinked\Mapper\CompanyMicrolearningExtendUserInstitutionMapper;
42
use LeadersLinked\Mapper\CompanyMicrolearningExtendUserProgramMapper;
43
use LeadersLinked\Mapper\CompanyMicrolearningExtendUserPartnerMapper;
44
use LeadersLinked\Mapper\CompanyMicrolearningExtendUserSectorMapper;
45
use LeadersLinked\Mapper\CompanyMicrolearningExtendUserStudentTypeMapper;
46
use LeadersLinked\Model\CompanyMicrolearningExtendUser;
47
use LeadersLinked\Model\CompanyMicrolearningExtendUserCompany;
48
use LeadersLinked\Model\CompanyMicrolearningExtendUserFunction;
49
use LeadersLinked\Model\CompanyMicrolearningExtendUserGroup;
50
use LeadersLinked\Model\CompanyMicrolearningExtendUserInstitution;
51
use LeadersLinked\Model\CompanyMicrolearningExtendUserProgram;
52
use LeadersLinked\Model\CompanyMicrolearningExtendUserPartner;
53
use LeadersLinked\Model\CompanyMicrolearningExtendUserSector;
54
use LeadersLinked\Model\CompanyMicrolearningExtendUserStudentType;
55
use LeadersLinked\Model\CompanyMicrolearningUser;
16998 efrain 56
use LeadersLinked\Model\Notification;
13755 efrain 57
use LeadersLinked\Mapper\ApplicationVariantMapper;
15394 efrain 58
use LeadersLinked\Mapper\CompanyMicrolearningExtendUserCountryMapper;
15452 efrain 59
use LeadersLinked\Model\CompanyMicrolearningExtendUserCountry;
15453 efrain 60
use LeadersLinked\Model\Network;
61
use LeadersLinked\Mapper\CompanyMapper;
62
use LeadersLinked\Mapper\NetworkMapper;
63
use LeadersLinked\Mapper\CompanyFollowerMapper;
64
use LeadersLinked\Mapper\ConnectionMapper;
65
use LeadersLinked\Model\Connection;
66
use LeadersLinked\Model\CompanyFollower;
16766 efrain 67
use LeadersLinked\Library\Functions;
16768 efrain 68
use LeadersLinked\Cache\CacheInterface;
69
use LeadersLinked\Cache\CacheImpl;
16998 efrain 70
use LeadersLinked\Mapper\NotificationMapper;
1 www 71
 
72
 
73
class MicrolearningAccessForStudentsController extends AbstractActionController
74
{
75
    /**
76
     *
16769 efrain 77
     * @var \Laminas\Db\Adapter\AdapterInterface
1 www 78
     */
79
    private $adapter;
80
 
81
    /**
82
     *
16769 efrain 83
     * @var \LeadersLinked\Cache\CacheInterface
1 www 84
     */
16769 efrain 85
    private $cache;
86
 
87
 
88
    /**
89
     *
90
     * @var \Laminas\Log\LoggerInterface
91
     */
1 www 92
    private $logger;
93
 
94
    /**
95
     *
96
     * @var array
97
     */
98
    private $config;
99
 
16769 efrain 100
 
1 www 101
    /**
16769 efrain 102
     *
103
     * @var \Laminas\Mvc\I18n\Translator
16768 efrain 104
     */
16769 efrain 105
    private $translator;
16768 efrain 106
 
16769 efrain 107
 
16768 efrain 108
    /**
1 www 109
     *
16769 efrain 110
     * @param \Laminas\Db\Adapter\AdapterInterface $adapter
111
     * @param \LeadersLinked\Cache\CacheInterface $cache
112
     * @param \Laminas\Log\LoggerInterface LoggerInterface $logger
1 www 113
     * @param array $config
16769 efrain 114
     * @param \Laminas\Mvc\I18n\Translator $translator
1 www 115
     */
16769 efrain 116
    public function __construct($adapter, $cache, $logger, $config, $translator)
1 www 117
    {
16769 efrain 118
        $this->adapter      = $adapter;
119
        $this->cache        = $cache;
120
        $this->logger       = $logger;
121
        $this->config       = $config;
122
        $this->translator   = $translator;
1 www 123
    }
124
 
125
    public function indexAction()
126
    {
127
        $currentUserPlugin = $this->plugin('currentUserPlugin');
128
        $currentUser = $currentUserPlugin->getUser();
129
        $currentCompany = $currentUserPlugin->getCompany();
130
 
131
        $request = $this->getRequest();
132
 
133
        if($request->isGet())
134
        {
135
 
136
            $headers  = $request->getHeaders();
137
 
138
            $isJson = false;
139
            if($headers->has('Accept')) {
140
                $accept = $headers->get('Accept');
141
 
142
                $prioritized = $accept->getPrioritized();
143
 
144
                foreach($prioritized as $key => $value) {
145
                    $raw = trim($value->getRaw());
146
 
147
                    if(!$isJson) {
148
                        $isJson = strpos($raw, 'json');
149
                    }
150
 
151
                }
152
            }
153
 
154
            if($isJson) {
16766 efrain 155
                $topic_uuid     = Functions::sanitizeFilterString($this->params()->fromQuery('topic_uuid'));
156
                $capsule_uuid   = Functions::sanitizeFilterString($this->params()->fromQuery('capsule_uuid'));
1 www 157
 
158
                $data = [
159
                    'link_upload' => '',
160
                    'items' => [] ,
161
                    'total' => 0,
162
 
163
                ];
164
 
165
 
166
                if(!$topic_uuid) {
167
                    return new JsonModel([
168
                        'success' => true,
169
                        'data' => $data
170
                    ]);
171
 
172
                }
173
 
174
 
175
                $topicMapper = CompanyMicrolearningTopicMapper::getInstance($this->adapter);
176
                $topic = $topicMapper->fetchOneByUuid($topic_uuid);
177
                if(!$topic) {
178
                    return new JsonModel([
179
                        'success' => true,
180
                        'data' => 'ERROR_TOPIC_NOT_FOUND'
181
                    ]);
182
                }
183
 
184
                if($topic->company_id != $currentCompany->id) {
185
                    return new JsonModel([
186
                        'success' => true,
187
                        'data' => 'ERROR_UNAUTHORIZED'
188
                    ]);
189
                }
190
 
191
 
192
 
193
                if(!$capsule_uuid) {
194
                    $capsuleMapper = CompanyMicrolearningCapsuleMapper::getInstance($this->adapter);
195
                    $records = $capsuleMapper->fetchAllByCompanyIdAndTopicId($topic->company_id, $topic->id);
196
 
197
                    $capsules = [];
198
                    foreach($records as $record)
199
                    {
200
                        if(!$capsule_uuid) {
201
                            $capsule_uuid = $record->uuid;
202
                        }
203
 
204
                        $capsules[ $record->uuid ] = $record->name;
205
                    }
206
 
207
                    $data['capsules']  = $capsules;
208
                }
209
 
210
                if(!$capsule_uuid) {
211
                    return new JsonModel([
212
                        'success' => true,
213
                        'data' => $data
214
                    ]);
215
 
216
                }
217
 
218
                $capsuleMapper = CompanyMicrolearningCapsuleMapper::getInstance($this->adapter);
219
                $capsule = $capsuleMapper->fetchOneByUuid($capsule_uuid);
220
 
221
 
222
 
223
                if(!$capsule) {
224
                    return new JsonModel([
225
                        'success' => true,
226
                        'data' => 'ERROR_CAPSULE_NOT_FOUND'
227
                    ]);
228
                }
229
 
230
                if($capsule->topic_id != $topic->id) {
231
                    return new JsonModel([
232
                        'success' => true,
233
                        'data' => 'ERROR_UNAUTHORIZED'
234
                    ]);
235
                }
236
 
237
 
238
                $data['link_upload'] = $this->url()->fromRoute('microlearning/access-for-students/upload',['topic_uuid' => $topic->uuid, 'capsule_uuid' => $capsule->uuid]);
239
                $data['link_notification'] = $this->url()->fromRoute('microlearning/access-for-students/notification',['topic_uuid' => $topic->uuid, 'capsule_uuid' => $capsule->uuid]);
240
 
241
                $search = $this->params()->fromQuery('search', []);
16766 efrain 242
                $search = empty($search['value']) ? '' :  Functions::sanitizeFilterString($search['value']);
1 www 243
 
244
                $page               = intval($this->params()->fromQuery('start', 1), 10);
245
                $records_x_page     = intval($this->params()->fromQuery('length', 10), 10);
246
                $order =  $this->params()->fromQuery('order', []);
247
                $order_field        = empty($order[0]['column']) ? 99 :  intval($order[0]['column'], 10);
16766 efrain 248
                $order_direction    = empty($order[0]['dir']) ? 'ASC' : strtoupper(Functions::sanitizeFilterString($order[0]['dir']));
1 www 249
 
250
                $fields =  ['uuid', 'first_name', 'last_name', 'email'];
251
                $order_field = isset($fields[$order_field]) ? $fields[$order_field] : 'first_name';
252
 
253
                if(!in_array($order_direction, ['ASC', 'DESC'])) {
254
                    $order_direction = 'ASC';
255
                }
256
 
257
                $acl = $this->getEvent()->getViewModel()->getVariable('acl');
258
                $allowRevoke = $acl->isAllowed($currentUser->usertype_id, 'microlearning/access-for-students/revoke');
259
                $allowUnlimit = $acl->isAllowed($currentUser->usertype_id, 'microlearning/access-for-students/unlimit');
260
                $allowCancel = $acl->isAllowed($currentUser->usertype_id, 'microlearning/access-for-students/cancel');
261
                $allowReactive = $acl->isAllowed($currentUser->usertype_id, 'microlearning/access-for-students/reactive');
262
 
263
                $queryMapper = QueryMapper::getInstance($this->adapter);
264
                $sql = $queryMapper->getSql();
265
                $select = $sql->select();
266
                $select->columns(['access', 'paid_from', 'paid_to', 'added_on', 'updated_on']);
267
                $select->from(['tb1' => CompanyMicrolearningCapsuleUserMapper::_TABLE] );
268
                $select->join(['tb2' => UserMapper::_TABLE], 'tb1.user_id = tb2.id', ['uuid', 'first_name', 'last_name', 'email']);
269
                $select->where->equalTo('tb1.company_id', $capsule->company_id);
270
                $select->where->equalTo('tb1.topic_id', $capsule->topic_id);
271
                $select->where->equalTo('tb1.capsule_id', $capsule->id);
272
 
273
                if($search) {
274
                    $select->where->nest()
275
                    ->like('first_name', '%' . $search . '%')
276
                    ->or->like('last_name', '%' . $search . '%')
277
                    ->or->like('email', '%' . $search . '%')
278
                    ->unnest();
279
 
280
                }
281
 
282
 
283
                $select->order($order_field . ' ' . $order_direction);
284
 
285
                $hydrator   = new ArraySerializableHydrator();
286
                $resultset  = new HydratingResultSet($hydrator);
287
 
288
                $adapter = new DbSelect($select, $sql, $resultset);
289
                $paginator = new Paginator($adapter);
290
                $paginator->setItemCountPerPage($records_x_page);
291
                $paginator->setCurrentPageNumber($page);
292
 
293
 
294
                $items = [ ];
295
                $records = $paginator->getCurrentItems();
296
                foreach($records as $record)
297
                {
298
                    $params = [
299
                        'topic_uuid' => $topic->uuid,
300
                        'capsule_uuid' => $capsule->uuid,
301
                        'user_uuid' => $record['uuid']
302
                    ];
303
 
304
                    $actions = [];
305
 
306
 
307
 
308
                    switch($record['access'])
309
                    {
310
                        case CompanyMicrolearningCapsuleUser::ACCESS_UNLIMITED :
311
                            $actions['link_revoke'] = $allowRevoke ? $this->url()->fromRoute('microlearning/access-for-students/revoke', $params) : '';
312
                            $details['access'] = 'LABEL_UNLIMIT';
313
                            break;
314
 
315
                        case CompanyMicrolearningCapsuleUser::ACCESS_REVOKE :
316
                            $actions['link_unlimit'] = $allowUnlimit ? $this->url()->fromRoute('microlearning/access-for-students/unlimit', $params) : '';
317
                            $details['access'] = 'LABEL_REVOKED';
318
                            break;
319
 
320
                        case CompanyMicrolearningCapsuleUser::ACCESS_PAY_PERIOD :
321
                            $actions['link_cancel'] = $allowCancel ? $this->url()->fromRoute('microlearning/access-for-students/cancel', $params) : '';
322
 
323
                            $dt_paid_from = \DateTime::createFromFormat('Y-m-d', $record['paid_from']);
324
                            $dt_paid_to = \DateTime::createFromFormat('Y-m-d', $record['paid_to']);
325
 
326
                            $details['access'] = 'LABEL_PAY_PERIOD';
327
                            $details['paid_from'] = $dt_paid_from->format('d/m/Y');
328
                            $details['paid_to'] = $dt_paid_to->format('d/m/Y');
329
                            break;
330
 
331
                        case CompanyMicrolearningCapsuleUser::ACCESS_SUPENDED :
332
                            $dt_paid_from = \DateTime::createFromFormat('Y-m-d', $record['paid_from']);
333
                            $dt_paid_to = \DateTime::createFromFormat('Y-m-d', $record['paid_to']);
334
 
335
                            $details['access'] = 'LABEL_SUSPENDED';
336
                            $details['paid_from'] = $dt_paid_from->format('d/m/Y');
337
                            $details['paid_to'] = $dt_paid_to->format('d/m/Y');
338
                            break;
339
 
340
                        case CompanyMicrolearningCapsuleUser::ACCESS_CANCELLED :
341
 
342
                            $date = date('Y-m-d');
343
                            if($allowCancel && $record['paid_from'] <= $date && $record['paid_to'] >= $date) {
344
                                $actions['link_reactive'] = $allowReactive ? $this->url()->fromRoute('microlearning/access-for-students/reactive', $params) : '';
345
                            }
346
 
347
                            $dt_paid_from = \DateTime::createFromFormat('Y-m-d', $record['paid_from']);
348
                            $dt_paid_to = \DateTime::createFromFormat('Y-m-d', $record['paid_to']);
349
 
350
                            $details['access'] = 'LABEL_CANCELLED';
351
                            $details['paid_from'] = $dt_paid_from->format('d/m/Y');
352
                            $details['paid_to'] = $dt_paid_to->format('d/m/Y');
353
                            break;
354
 
355
                    }
356
 
357
                    $dt_added_on = \DateTime::createFromFormat('Y-m-d H:i:s', $record['added_on']);
358
                    $details['added_on'] = $dt_added_on->format('d/m/Y h:i a');
359
 
360
                    $dt_updated_on = \DateTime::createFromFormat('Y-m-d H:i:s', $record['updated_on']);
361
                    $details['updated_on'] = $dt_updated_on->format('d/m/Y h:i a');
362
 
363
                    $item = [
364
                        'uuid' => $record['uuid'],
365
                        'first_name' => $record['first_name'],
366
                        'last_name' => $record['last_name'],
367
                        'email' => $record['email'],
368
                        'details' => $details,
369
                        'actions' => $actions
370
                    ];
371
 
372
 
373
                    array_push($items, $item);
374
 
375
 
376
                }
377
 
378
                $data['items'] = $items;
379
                $data['total'] = $paginator->getTotalItemCount();
380
 
381
 
382
                return new JsonModel([
383
                    'success' => true,
384
                    'data' => $data
385
                ]);
386
            } else {
387
                $topicMapper = CompanyMicrolearningTopicMapper::getInstance($this->adapter);
388
                $topics = $topicMapper->fetchAllByCompanyId($currentCompany->id);
389
 
390
                if($topics) {
391
                    $topic_id = $topics[0]->id;
392
                }  else {
393
                    $topic_id = 0;
394
                }
395
 
396
 
397
                $form = new TopicCapsuleForm($this->adapter, $currentCompany->id, $topic_id);
15355 efrain 398
                $formPushNotification = new PushMicrolearningNotificationForm($this->adapter, $currentCompany->id);
1 www 399
                $formCapsuleCustomer = new CapsuleCustomerUploadForm();
400
 
401
 
402
 
403
                $this->layout()->setTemplate('layout/layout-backend');
404
                $viewModel = new ViewModel();
405
                $viewModel->setTemplate('leaders-linked/microlearning-access-for-students/index.phtml');
406
                $viewModel->setVariables([
407
                    'form' => $form,
408
                    'formPushNotification' => $formPushNotification,
409
                    'formCapsuleCustomer' => $formCapsuleCustomer
410
                ]);
411
 
412
                return $viewModel ;
413
            }
414
 
415
        } else {
416
            return new JsonModel([
417
                'success' => false,
418
                'data' => 'ERROR_METHOD_NOT_ALLOWED'
187 efrain 419
            ]);
1 www 420
        }
421
    }
422
 
423
 
424
 
425
 
426
    public function revokeAction()
427
    {
428
        $request = $this->getRequest();
429
 
430
        $currentUserPlugin = $this->plugin('currentUserPlugin');
431
        $currentUser    = $currentUserPlugin->getUser();
432
        $currentCompany = $currentUserPlugin->getCompany();
433
 
434
        $request    = $this->getRequest();
435
        $topic_uuid     = $this->params()->fromRoute('topic_uuid');
436
        $capsule_uuid   = $this->params()->fromRoute('capsule_uuid');
437
        $user_uuid   = $this->params()->fromRoute('user_uuid');
438
 
439
 
440
        $topicMapper = CompanyMicrolearningTopicMapper::getInstance($this->adapter);
441
        $topic = $topicMapper->fetchOneByUuid($topic_uuid);
442
        if(!$topic) {
443
            return new JsonModel([
444
                'success'   => false,
445
                'data'   => 'ERROR_TOPIC_NOT_FOUND'
446
            ]);
447
        }
448
 
449
 
450
 
451
        if($topic->company_id != $currentCompany->id) {
452
            return new JsonModel([
453
                'success'   => false,
454
                'data'   => 'ERROR_UNAUTHORIZED'
455
            ]);
456
        }
457
 
458
        $capsuleMapper = CompanyMicrolearningCapsuleMapper::getInstance($this->adapter);
459
        $capsule = $capsuleMapper->fetchOneByUuid($capsule_uuid);
460
        if(!$capsule) {
461
            return new JsonModel([
462
                'success'   => false,
463
                'data'   => 'ERROR_CAPSULE_NOT_FOUND'
464
            ]);
465
        }
466
 
467
 
468
        if($capsule->topic_id != $topic->id) {
469
            return new JsonModel([
470
                'success'   => false,
471
                'data'   => 'ERROR_UNAUTHORIZED'
472
            ]);
473
        }
474
 
475
        $userMapper = UserMapper::getInstance($this->adapter);
476
        $user = $userMapper->fetchOneByUuid($user_uuid);
477
 
478
        if(!$user) {
479
            return new JsonModel([
480
                'success'   => false,
481
                'data'   => 'ERROR_USER_NOT_FOUND'
482
            ]);
483
        }
484
 
485
        $capsuleUserMapper = CompanyMicrolearningCapsuleUserMapper::getInstance($this->adapter);
486
        $capsuleUser = $capsuleUserMapper->fetchOneByUserIdAndCapsuleId($user->id, $capsule->id);
487
        if(!$capsuleUser) {
488
            return new JsonModel([
489
                'success'   => false,
490
                'data'   => 'ERROR_UNAUTHORIZED'
491
            ]);
492
        }
493
 
494
        if($request->isPost()) {
495
 
496
 
497
            if($capsuleUser->access != CompanyMicrolearningCapsuleUser::ACCESS_UNLIMITED) {
498
                return new JsonModel([
499
                    'success'   => false,
500
                    'data'   => 'ERROR_USER_ACCESS_CANNT_BE_REVOKE'
501
                ]);
502
            }
503
            $capsuleUser->access = CompanyMicrolearningCapsuleUser::ACCESS_REVOKE;
504
            if($capsuleUserMapper->update($capsuleUser)) {
505
 
506
                $capsuleUser = $capsuleUserMapper->fetchOne($capsuleUser->id);
507
                if($capsuleUser) {
508
                    $companyMicrolearningUserMapper = CompanyMicrolearningUserMapper::getInstance($this->adapter);
509
                    $companyMicrolearningUser = $companyMicrolearningUserMapper->fetchOneByUserIdAndCompanyId($capsuleUser->user_id, $capsuleUser->company_id);
510
                    if($companyMicrolearningUser) {
511
                        $companyMicrolearningUser->updated_on = $capsuleUser->updated_on;
512
 
513
                        $companyMicrolearningUserMapper->update($companyMicrolearningUser);
514
 
515
                    } else {
516
                        $companyMicrolearningUser = new CompanyMicrolearningUser();
517
                        $companyMicrolearningUser->company_id = $capsuleUser->company_id;
518
                        $companyMicrolearningUser->user_id = $capsuleUser->user_id;
519
                        $companyMicrolearningUser->added_on = $capsuleUser->added_on;
520
                        $companyMicrolearningUser->updated_on = $capsuleUser->updated_on;
521
 
522
                        $companyMicrolearningUserMapper->insert($companyMicrolearningUser);
523
                    }
524
                }
525
 
526
                return new JsonModel([
527
                    'success' => true,
528
                    'data' => 'LABEL_USER_ACCESS_HAS_BEEN_REVOKE'
529
                ]);
530
 
531
            } else {
532
 
533
                return new JsonModel([
534
                    'success'   => false,
535
                    'data'      => $capsuleUserMapper->getError()
536
                ]);
537
            }
538
        }
539
 
540
        return new JsonModel([
541
            'success' => false,
542
            'data' => 'ERROR_METHOD_NOT_ALLOWED'
543
        ]);
544
    }
545
 
546
    public function unlimitAction()
547
    {
548
        $request = $this->getRequest();
549
 
550
        $currentUserPlugin = $this->plugin('currentUserPlugin');
551
        $currentUser    = $currentUserPlugin->getUser();
552
        $currentCompany = $currentUserPlugin->getCompany();
553
 
554
        $request    = $this->getRequest();
555
        $topic_uuid     = $this->params()->fromRoute('topic_uuid');
556
        $capsule_uuid   = $this->params()->fromRoute('capsule_uuid');
557
        $user_uuid   = $this->params()->fromRoute('user_uuid');
558
 
559
 
560
        $topicMapper = CompanyMicrolearningTopicMapper::getInstance($this->adapter);
561
        $topic = $topicMapper->fetchOneByUuid($topic_uuid);
562
        if(!$topic) {
563
            return new JsonModel([
564
                'success'   => false,
565
                'data'   => 'ERROR_TOPIC_NOT_FOUND'
566
            ]);
567
        }
568
 
569
 
570
 
571
        if($topic->company_id != $currentCompany->id) {
572
            return new JsonModel([
573
                'success'   => false,
574
                'data'   => 'ERROR_UNAUTHORIZED'
575
            ]);
576
        }
577
 
578
        $capsuleMapper = CompanyMicrolearningCapsuleMapper::getInstance($this->adapter);
579
        $capsule = $capsuleMapper->fetchOneByUuid($capsule_uuid);
580
        if(!$capsule) {
581
            return new JsonModel([
582
                'success'   => false,
583
                'data'   => 'ERROR_CAPSULE_NOT_FOUND'
584
            ]);
585
        }
586
 
587
 
588
        if($capsule->topic_id != $topic->id) {
589
            return new JsonModel([
590
                'success'   => false,
591
                'data'   => 'ERROR_UNAUTHORIZED'
592
            ]);
593
        }
594
 
595
        $userMapper = UserMapper::getInstance($this->adapter);
596
        $user = $userMapper->fetchOneByUuid($user_uuid);
597
 
598
        if(!$user) {
599
            return new JsonModel([
600
                'success'   => false,
601
                'data'   => 'ERROR_USER_NOT_FOUND'
602
            ]);
603
        }
604
 
605
        $capsuleUserMapper = CompanyMicrolearningCapsuleUserMapper::getInstance($this->adapter);
606
        $capsuleUser = $capsuleUserMapper->fetchOneByUserIdAndCapsuleId($user->id, $capsule->id);
607
        if(!$capsuleUser) {
608
            return new JsonModel([
609
                'success'   => false,
610
                'data'   => 'ERROR_UNAUTHORIZED'
611
            ]);
612
        }
613
 
614
        if($request->isPost()) {
615
 
616
 
617
            if($capsuleUser->access != CompanyMicrolearningCapsuleUser::ACCESS_REVOKE) {
618
                return new JsonModel([
619
                    'success'   => false,
620
                    'data'   => 'ERROR_USER_ACCESS_CANNT_BE_UNLIMIT'
621
                ]);
622
            }
623
            $capsuleUser->access = CompanyMicrolearningCapsuleUser::ACCESS_UNLIMITED;
624
            if($capsuleUserMapper->update($capsuleUser)) {
625
 
626
                $capsuleUser = $capsuleUserMapper->fetchOne($capsuleUser->id);
627
                if($capsuleUser) {
628
                    $companyMicrolearningUserMapper = CompanyMicrolearningUserMapper::getInstance($this->adapter);
629
                    $companyMicrolearningUser = $companyMicrolearningUserMapper->fetchOneByUserIdAndCompanyId($capsuleUser->user_id, $capsuleUser->company_id);
630
                    if($companyMicrolearningUser) {
631
                        $companyMicrolearningUser->updated_on = $capsuleUser->updated_on;
632
 
633
                        $companyMicrolearningUserMapper->update($companyMicrolearningUser);
634
 
635
                    } else {
636
                        $companyMicrolearningUser = new CompanyMicrolearningUser();
637
                        $companyMicrolearningUser->company_id = $capsuleUser->company_id;
638
                        $companyMicrolearningUser->user_id = $capsuleUser->user_id;
639
                        $companyMicrolearningUser->added_on = $capsuleUser->added_on;
640
                        $companyMicrolearningUser->updated_on = $capsuleUser->updated_on;
641
 
642
                        $companyMicrolearningUserMapper->insert($companyMicrolearningUser);
643
                    }
644
                }
645
 
646
                return new JsonModel([
647
                    'success' => true,
648
                    'data' => 'LABEL_USER_ACCESS_HAS_BEEN_UNLIMITED'
649
                ]);
650
 
651
            } else {
652
 
653
                return new JsonModel([
654
                    'success'   => false,
655
                    'data'      => $capsuleUserMapper->getError()
656
                ]);
657
            }
658
        }
659
 
660
        return new JsonModel([
661
            'success' => false,
662
            'data' => 'ERROR_METHOD_NOT_ALLOWED'
663
        ]);
664
    }
665
 
666
    public function uploadAction()
667
    {
668
        $request = $this->getRequest();
669
 
670
        $currentUserPlugin = $this->plugin('currentUserPlugin');
671
        $currentUser    = $currentUserPlugin->getUser();
672
        $currentCompany = $currentUserPlugin->getCompany();
673
 
15394 efrain 674
        $currentNetworkPlugin = $this->plugin('currentNetworkPlugin');
675
        $currentNetwork = $currentNetworkPlugin->getNetwork();
676
 
1 www 677
        $request    = $this->getRequest();
678
        $topic_uuid     = $this->params()->fromRoute('topic_uuid');
679
        $capsule_uuid   = $this->params()->fromRoute('capsule_uuid');
680
 
681
 
682
        $topicMapper = CompanyMicrolearningTopicMapper::getInstance($this->adapter);
683
        $topic = $topicMapper->fetchOneByUuid($topic_uuid);
684
        if(!$topic) {
685
            return new JsonModel([
686
                'success'   => false,
687
                'data'   => 'ERROR_TOPIC_NOT_FOUND'
688
            ]);
689
        }
690
 
691
 
692
 
693
        if($topic->company_id != $currentCompany->id) {
694
            return new JsonModel([
695
                'success'   => false,
696
                'data'   => 'ERROR_UNAUTHORIZED'
697
            ]);
698
        }
699
 
700
        $capsuleMapper = CompanyMicrolearningCapsuleMapper::getInstance($this->adapter);
701
        $capsule = $capsuleMapper->fetchOneByUuid($capsule_uuid);
702
        if(!$capsule) {
703
            return new JsonModel([
704
                'success'   => false,
705
                'data'   => 'ERROR_CAPSULE_NOT_FOUND'
706
            ]);
707
        }
708
 
709
 
710
        if($capsule->topic_id != $topic->id) {
711
            return new JsonModel([
712
                'success'   => false,
713
                'data'   => 'ERROR_UNAUTHORIZED'
714
            ]);
715
        }
716
 
717
 
718
 
719
        if($request->isPost()) {
720
 
16766 efrain 721
            $step = Functions::sanitizeFilterString($this->params()->fromPost('step'));
1 www 722
            if($step == 'validation') {
15455 efrain 723
 
724
 
1 www 725
                $userMapper = UserMapper::getInstance($this->adapter);
726
                $capsuleUserMapper = CompanyMicrolearningCapsuleUserMapper::getInstance($this->adapter);
727
 
728
                $form = new  CapsuleCustomerUploadForm();
729
                $dataPost = array_merge($request->getPost()->toArray(), $request->getFiles()->toArray());
730
 
731
                $form->setData($dataPost);
732
 
733
                if($form->isValid()) {
734
 
735
                    $file = $_FILES['file'];
736
                    $tmp_filename = $file['tmp_name'];
737
                    $final_filename =  'data/' . $file['name'];
738
 
739
                    if(!move_uploaded_file($tmp_filename, $final_filename)) {
740
                        return new JsonModel([
741
                            'success' => false,
742
                            'data' => 'ERROR_UPLOAD_FILE'
743
                        ]);
744
                    }
745
 
15455 efrain 746
 
16983 efrain 747
                    $count_users = 0;
1 www 748
                    $users = [];
16983 efrain 749
                    $count_errors = 0;
750
                    $errors = [];
1 www 751
 
752
 
753
                    $spreadsheet = IOFactory::load($final_filename);
754
                    $records = $spreadsheet->getActiveSheet()->toArray(null, true, true, true);
755
 
756
                    $emails = [];
16983 efrain 757
                    $row = 0;
1 www 758
 
759
                    foreach($records as $record)
760
                    {
15452 efrain 761
                        /*
762
                        A = Nombre
763
                        B = Apellido
764
                        C = Email
765
                        D = Contraseña
766
                        E = Empresa
767
                        F = Función
768
                        G = Grupo
769
                        H = Institución
770
                        I = Programa
771
                        J = Socio
772
                        K = Sector
773
                        L = Tipo de Estudiante
774
                        M = País
775
                        N = Es adulto
776
                        */
16983 efrain 777
                        $row++;
1 www 778
 
779
 
16766 efrain 780
                        $first_name = Functions::sanitizeFilterString($record['A']);
781
                        $last_name = Functions::sanitizeFilterString($record['B']);
15394 efrain 782
                        $email = trim(filter_var($record['C'], FILTER_SANITIZE_EMAIL));
16766 efrain 783
                        $password = Functions::sanitizeFilterString($record['D']);
1 www 784
 
16766 efrain 785
                        $company =  isset($record['E']) ? Functions::sanitizeFilterString($record['E']) : '';
786
                        $function = isset($record['F']) ? Functions::sanitizeFilterString($record['F']) : '';
787
                        $group = isset($record['G']) ? Functions::sanitizeFilterString($record['G']) : '';
788
                        $institution = isset($record['H']) ? Functions::sanitizeFilterString($record['H']) : '';
789
                        $program = isset($record['I']) ? Functions::sanitizeFilterString($record['I']) : '';
790
                        $partner = isset($record['J']) ? Functions::sanitizeFilterString($record['J']) : '';
791
                        $sector = isset($record['K']) ? Functions::sanitizeFilterString($record['K']) : '';
792
                        $studentType = isset($record['L']) ? Functions::sanitizeFilterString($record['L']) : '';
793
                        $country =  isset($record['M']) ? Functions::sanitizeFilterString($record['M']) : '';
794
                        $isAdult = isset($record['N']) ? Functions::sanitizeFilterString($record['N']) : '';
15452 efrain 795
 
15394 efrain 796
 
16983 efrain 797
                        if($row == 1) {
798
                            continue;
799
                        }
15394 efrain 800
 
129 efrain 801
                        //||  empty($password)
802
                        if(empty($first_name) || empty($last_name) || !filter_var($email, FILTER_VALIDATE_EMAIL) ) {
16983 efrain 803
 
804
 
805
 
1 www 806
                            continue;
16983 efrain 807
 
1 www 808
                        }
809
 
810
                        if(!in_array($email, $emails)) {
811
 
812
                            $user = $userMapper->fetchOneByEmail($email);
813
                            if($user) {
814
                                $assigned_capsules =  $capsuleUserMapper->fetchCountByCompanyIdAndTopicIdAndUserId($topic->company_id, $topic->id, $user->id);
815
                            } else {
816
                                $assigned_capsules = 0;
817
                            }
818
 
16983 efrain 819
                            $count_users++;
820
 
1 www 821
                            array_push($emails, $email);
822
                            array_push($users, [
16983 efrain 823
                                'id' => $count_users,
1 www 824
                                'first_name' => $first_name,
825
                                'last_name' => $last_name,
826
                                'password'  => $password,
827
                                'email' => $email,
828
                                'assigned_capsules' => $assigned_capsules,
15452 efrain 829
                                'company' => $company,
830
                                'function' => $function,
831
                                'group' => $group,
832
                                'institution' => $institution,
833
                                'program' => $program,
834
                                'partner' => $partner,
835
                                'sector' => $sector,
836
                                'studentType' => $studentType,
837
                                'country' => $country,
838
                                'isAdult' => $isAdult,
1 www 839
                            ]);
16983 efrain 840
                        } else {
841
                            $count_errors++;
842
                            array_push($errors,[
843
                                'id' => $count_errors,
844
                                'first_name' => $first_name,
845
                                'last_name' => $last_name,
846
                                'password'  => $password,
847
                                'email' => $email,
848
                                'status' => 'DUPLICATE IN EXCEL'
849
                            ]);
1 www 850
                        }
851
 
852
 
853
 
854
 
855
 
856
                    }
15457 efrain 857
 
1 www 858
 
859
                    $key = md5($currentUser->id . '-' . $topic->uuid . '-' . $capsule->uuid);
860
                    $this->cache->setItem($key, serialize($users));
861
 
862
                    return new JsonModel([
863
                        'success' => true,
864
                        'data' => [
865
                            'key' => $key,
866
                            'topic' => $topic->name,
867
                            'capsule' => $capsule->name,
16983 efrain 868
                            'items' => [
869
                                'ok' => $users,
870
                                'error' => $errors,
871
                            ],
1 www 872
                        ]
873
                    ]);
874
 
875
 
876
 
877
                } else {
878
                    $messages = [];
879
                    $form_messages = (array) $form->getMessages();
880
                    foreach($form_messages  as $fieldname => $field_messages)
881
                    {
882
 
883
                        $messages[$fieldname] = array_values($field_messages);
884
                    }
885
 
886
                    return new JsonModel([
887
                        'success'   => false,
888
                        'data'   => $messages
889
                    ]);
890
                }
891
            } else if($step == 'process') {
892
 
16766 efrain 893
                $key = Functions::sanitizeFilterString($this->params()->fromPost('key'));
1 www 894
                if(!$key) {
895
                    return new JsonModel([
896
                        'success' => false,
897
                        'data' => 'ERROR_CACHE_KEY_EMPTY'
898
                    ]);
899
                }
900
 
901
                $value = $this->cache->getItem($key);
902
                if(!$value) {
903
 
904
                    return new JsonModel([
905
                        'success' => false,
906
                        'data' => 'ERROR_CACHE_NOT_FOUND'
907
                    ]);
908
                }
909
 
910
                $records = unserialize($value);
911
                if(!$records) {
912
                    return new JsonModel([
913
                        'success' => false,
914
                        'data' => 'ERROR_CACHE_INVALID'
915
                    ]);
916
                }
917
 
16983 efrain 918
 
15455 efrain 919
 
16983 efrain 920
 
15453 efrain 921
                $networkMapper = NetworkMapper::getInstance($this->adapter);
922
                $companyMapper = CompanyMapper::getInstance($this->adapter);
923
                $companyFollowerMapper = CompanyFollowerMapper::getInstance($this->adapter);
924
 
925
                $connectionMapper = ConnectionMapper::getInstance($this->adapter);
1 www 926
                $userMapper = UserMapper::getInstance($this->adapter);
927
                $userPasswordMapper = UserPasswordMapper::getInstance($this->adapter);
928
                $capsuleUserMapper = CompanyMicrolearningCapsuleUserMapper::getInstance($this->adapter);
929
 
930
                $companyMicrolearningExtendUserMapper = CompanyMicrolearningExtendUserMapper::getInstance($this->adapter);
931
                $companyMicrolearningExtendUserCompanyMapper = CompanyMicrolearningExtendUserCompanyMapper::getInstance($this->adapter);
932
                $companyMicrolearningExtendUserFunctionMapper = CompanyMicrolearningExtendUserFunctionMapper::getInstance($this->adapter);
933
                $companyMicrolearningExtendUserGroupMapper = CompanyMicrolearningExtendUserGroupMapper::getInstance($this->adapter);
934
                $companyMicrolearningExtendUserInstitutionMapper = CompanyMicrolearningExtendUserInstitutionMapper::getInstance($this->adapter);
935
                $companyMicrolearningExtendUserProgramMapper = CompanyMicrolearningExtendUserProgramMapper::getInstance($this->adapter);
936
                $companyMicrolearningExtendUserPartnerMapper = CompanyMicrolearningExtendUserPartnerMapper::getInstance($this->adapter);
937
                $companyMicrolearningExtendUserSectorMapper = CompanyMicrolearningExtendUserSectorMapper::getInstance($this->adapter);
938
                $companyMicrolearningExtendUserStudentTypeMapper = CompanyMicrolearningExtendUserStudentTypeMapper::getInstance($this->adapter);
15394 efrain 939
                $companyMicrolearningExtendUserCountryMapper = CompanyMicrolearningExtendUserCountryMapper::getInstance($this->adapter);
4 efrain 940
 
1 www 941
 
15453 efrain 942
                $networkDefault = $networkMapper->fetchOneByDefault();
943
 
944
                //print_r($networkDefault);
945
 
946
                $userDefaultForConnection = $userMapper->fetchOneDefaultForConnection();
947
 
948
                //print_r($userDefaultForConnection);
949
 
950
 
951
                $companyForFollower = $companyMapper->fetchOneDefaultForFollowers();
952
                //print_r($companyForFollower);
15457 efrain 953
 
16983 efrain 954
                $csv = "FIRST NAME|LAST NAME|EMAIL|STATUS\r\n";
955
 
4 efrain 956
 
15457 efrain 957
                $users_processed = 0;
1 www 958
                $users_assigned = 0;
959
                $user_ids = [];
960
                foreach($records as $record)
961
                {
962
                    $first_name = $record['first_name'];
963
                    $last_name = $record['last_name'];
964
                    $password = $record['password'];
965
                    $email = $record['email'];
966
 
967
 
15452 efrain 968
                    $company = $record['company'];
969
                    $function = $record['function'];
970
                    $group = $record['group'];
971
                    $institution = $record['institution'];
972
                    $program = $record['program'];
973
                    $partner = $record['partner'];
974
                    $sector = $record['sector'];
975
                    $studentType = $record['studentType'];
976
                    $country = $record['country'];
15453 efrain 977
                    $isAdult = strtolower(trim( $record['isAdult'])) == User::IS_ADULT_YES;
978
 
979
 
1 www 980
                    $user = $userMapper->fetchOneByEmail($email);
981
                    if(!$user) {
982
 
983
 
129 efrain 984
                        if($password) {
985
                            $password_hash = password_hash($password, PASSWORD_DEFAULT);
986
 
987
                            $user = new User();
988
 
15452 efrain 989
                            $user->network_id = $currentNetwork->id;
129 efrain 990
                            $user->blocked = User::BLOCKED_NO;
991
                            $user->email_verified = User::EMAIL_VERIFIED_YES;
992
                            $user->email = $email;
993
                            $user->first_name = $first_name;
994
                            $user->last_name = $last_name;
995
                            $user->password = $password_hash;
996
                            $user->login_attempt = 0;
997
                            $user->usertype_id = UserType::USER;
998
                            $user->status = User::STATUS_ACTIVE;
15453 efrain 999
                            $user->is_adult = $isAdult ? User::IS_ADULT_YES : User::IS_ADULT_NO;
129 efrain 1000
 
1001
                            $result = $userMapper->insert($user);
1002
                            if($result) {
1003
                                $userPassword = new UserPassword();
1004
                                $userPassword->user_id = $user->id;
1005
                                $userPassword->password = $password_hash;
1006
                                $userPasswordMapper->insert($userPassword);
16983 efrain 1007
 
1008
 
1009
                                $csv .= "$first_name|$last_name|$email|CREATE USER \r\n";
129 efrain 1010
                            } else {
16983 efrain 1011
                                $csv .= "$first_name|$last_name|$email|FAIL CREATE USER \r\n";
1012
 
129 efrain 1013
                                continue;
1014
                            }
15453 efrain 1015
 
129 efrain 1016
                        }
1017
                    } else {
15453 efrain 1018
                        $user->is_adult = $isAdult ? User::IS_ADULT_YES : User::IS_ADULT_NO;
129 efrain 1019
                        if($user->email_verified == User::EMAIL_VERIFIED_NO || $user->status != User::STATUS_ACTIVE) {
1020
                            $user->email_verified = User::EMAIL_VERIFIED_YES;
1021
                            $user->status != User::STATUS_ACTIVE;
1022
 
15453 efrain 1023
 
129 efrain 1024
                        }
15453 efrain 1025
                        if(!$userMapper->update($user)) {
16983 efrain 1026
                            $csv .= "$first_name|$last_name|$email|FAIL UPDATE USER \r\n";
15453 efrain 1027
                            continue;
1028
                        }
129 efrain 1029
 
1030
 
1 www 1031
                    }
1032
 
15453 efrain 1033
 
1034
                    $user_id_in_default_network = 0;
1035
                    if($user->is_adult == User::IS_ADULT_YES) {
1036
 
1037
                        if($currentNetwork->default == Network::DEFAULT_YES) {
1038
 
1039
                            $user_id_in_default_network = $user->id;
1040
 
1041
 
1042
 
1043
                        } else {
1044
 
1045
                            $userInDefaultNetwork = $userMapper->fetchOneByEmailAndNetworkId($user->email, $networkDefault->id);
1046
                            if($userInDefaultNetwork) {
1047
                                $user_id_in_default_network = $userInDefaultNetwork->id;
1048
 
1049
                                if($userInDefaultNetwork->email_verified == User::EMAIL_VERIFIED_NO || $userInDefaultNetwork->status != User::STATUS_ACTIVE) {
1050
                                    $userInDefaultNetwork->email_verified = User::EMAIL_VERIFIED_YES;
1051
                                    $userInDefaultNetwork->status != User::STATUS_ACTIVE;
1052
 
1053
                                    if(!$userMapper->update($userInDefaultNetwork)) {
16983 efrain 1054
                                        $csv .= "$first_name|$last_name|$email|FAIL UPDATE USER IN DEFAULT NETWORK \r\n";
15453 efrain 1055
                                        continue;
1056
                                    }
1057
                                }
1058
 
1059
 
1060
                            } else {
1061
                                $userInDefaultNetwork = new User();
1062
                                $userInDefaultNetwork->network_id = $networkDefault->id;
1063
                                $userInDefaultNetwork->blocked = User::BLOCKED_NO;
1064
                                $userInDefaultNetwork->email_verified = User::EMAIL_VERIFIED_YES;
1065
                                $userInDefaultNetwork->email = $email;
1066
                                $userInDefaultNetwork->first_name = $first_name;
1067
                                $userInDefaultNetwork->last_name = $last_name;
1068
                                $userInDefaultNetwork->password = $password_hash;
1069
                                $userInDefaultNetwork->login_attempt = 0;
1070
                                $userInDefaultNetwork->usertype_id = UserType::USER;
1071
                                $userInDefaultNetwork->status = User::STATUS_ACTIVE;
1072
                                $userInDefaultNetwork->is_adult = $isAdult == User::IS_ADULT_YES;
1073
                                $result = $userMapper->insert($userInDefaultNetwork);
1074
                                if($result) {
1075
                                    $user_id_in_default_network = $userInDefaultNetwork->id;
1076
 
1077
 
1078
                                    $userPassword = new UserPassword();
1079
                                    $userPassword->user_id = $userInDefaultNetwork->id;
1080
                                    $userPassword->password = $password_hash;
1081
                                    $userPasswordMapper->insert($userPassword);
16983 efrain 1082
 
1083
                                    $csv .= "$first_name|$last_name|$email|CREATE USER IN DEFAULT NETWORK \r\n";
1084
                                } else {
1085
                                    $csv .= "$first_name|$last_name|$email|FAIL CREATE USER IN DEFAULT NETWORK \r\n";
15453 efrain 1086
                                }
1087
 
1088
                            }
1089
 
1090
 
1091
                        }
1092
                    }
1093
 
1094
                    if($user_id_in_default_network) {
1095
 
1096
                        if($userDefaultForConnection) {
1097
 
1098
                            $connection = $connectionMapper->fetchOneByUserId1AndUserId2($userDefaultForConnection->id, $user_id_in_default_network);
1099
                            if($connection) {
1100
                                if($connection->status != Connection::STATUS_ACCEPTED) {
1101
                                    $connection->status = Connection::STATUS_ACCEPTED;
1102
                                    $connectionMapper->update($connection);
1103
 
1104
                                }
1105
 
1106
 
1107
                            } else {
1108
                                $connection = new Connection();
1109
                                $connection->request_to = $user_id_in_default_network;
1110
                                $connection->request_from = $userDefaultForConnection->id;
1111
                                $connection->status = Connection::STATUS_ACCEPTED;
1112
                                $connectionMapper->insert($connection);
1113
                            }
1114
                        }
1115
 
1116
                        if($companyForFollower) {
1117
                            $companyFollower = $companyFollowerMapper->fetchOneByCompanyIdAndUserId($companyForFollower->id, $user_id_in_default_network);
1118
                            if(!$companyFollower) {
1119
                                $companyFollower = new CompanyFollower();
1120
                                $companyFollower->company_id = $companyForFollower->id;
1121
                                $companyFollower->follower_id = $user_id_in_default_network;
1122
 
1123
                                $companyFollowerMapper->insert($companyFollower);
1124
 
1125
 
1126
                            }
1127
                        }
1128
 
1129
 
1130
                    }
1131
 
1132
 
1 www 1133
                    if(!in_array($user->id, $user_ids)) {
1134
                        array_push($user_ids, $user->id);
1135
                    }
1136
 
4 efrain 1137
                    /*
1138
                    echo '$filterCompany = ' . $filterCompany . PHP_EOL;
1139
                    echo '$filterFunctio = ' . $filterFunction . PHP_EOL;
1140
                    echo '$filterGroup = ' . $filterGroup . PHP_EOL;
1141
                    echo '$filterInstitution = ' . $filterInstitution . PHP_EOL;
1142
                    echo '$filterPartner = ' . $filterPartner . PHP_EOL;
1143
                    echo '$filterProgram = ' . $filterProgram . PHP_EOL;
1144
                    echo '$filterSector = ' . $filterSector . PHP_EOL;
1145
                    echo '$filterStudentType = ' . $filterStudentType . PHP_EOL;
1146
                  */
1147
 
1148
 
1149
                    $extendUser = $companyMicrolearningExtendUserMapper->fetchOneByCompanyIdAndUserId($currentCompany->id, $user->id);
1150
                    if(!$extendUser) {
1151
                        $extendUser = new CompanyMicrolearningExtendUser();
1152
                        $extendUser->company_id = $currentCompany->id;
1153
                        $extendUser->user_id = $user->id;
1154
                    }
1155
 
1156
 
15452 efrain 1157
                    if($company) {
1158
                        $record = $companyMicrolearningExtendUserCompanyMapper->fetchOneByCompanyIdAndName($currentCompany->id, $company);
4 efrain 1159
 
1160
                        if(!$record) {
1161
                            $record = new CompanyMicrolearningExtendUserCompany();
1162
                            $record->company_id = $currentCompany->id;
15452 efrain 1163
                            $record->name = $company;
1 www 1164
 
4 efrain 1165
                            $companyMicrolearningExtendUserCompanyMapper->insert($record);
1166
                        }
1167
 
1168
 
1169
 
1 www 1170
 
4 efrain 1171
                        if($record->id) {
1172
                            $extendUser->extend_company_id = $record->id;
1173
                        }
1174
                    }
1 www 1175
 
15452 efrain 1176
                    if($function) {
1177
                        $record = $companyMicrolearningExtendUserFunctionMapper->fetchOneByCompanyIdAndName($currentCompany->id, $function);
4 efrain 1178
                        if(!$record) {
1179
                            $record = new CompanyMicrolearningExtendUserFunction();
1180
                            $record->company_id = $currentCompany->id;
15452 efrain 1181
                            $record->name = $function;
1 www 1182
 
4 efrain 1183
                            $companyMicrolearningExtendUserFunctionMapper->insert($record);
1184
                        }
1 www 1185
 
4 efrain 1186
                        if($record->id) {
1187
                            $extendUser->extend_function_id = $record->id;
1188
                        }
1189
                    }
1 www 1190
 
15452 efrain 1191
                    if($group) {
1192
                        $record = $companyMicrolearningExtendUserGroupMapper->fetchOneByCompanyIdAndName($currentCompany->id, $group);
4 efrain 1193
                        if(!$record) {
1194
                            $record = new CompanyMicrolearningExtendUserGroup();
1195
                            $record->company_id = $currentCompany->id;
15452 efrain 1196
                            $record->name = $group;
1 www 1197
 
4 efrain 1198
                            $companyMicrolearningExtendUserGroupMapper->insert($record);
1199
                        }
1 www 1200
 
4 efrain 1201
                        if($record->id) {
1202
                            $extendUser->extend_group_id = $record->id;
1203
                        }
1204
                    }
1 www 1205
 
15452 efrain 1206
                    if($institution) {
1207
                        $record = $companyMicrolearningExtendUserInstitutionMapper->fetchOneByCompanyIdAndName($currentCompany->id, $institution);
4 efrain 1208
                        if(!$record) {
1209
                            $record = new CompanyMicrolearningExtendUserInstitution();
1210
                            $record->company_id = $currentCompany->id;
15452 efrain 1211
                            $record->name = $institution;
1 www 1212
 
4 efrain 1213
                            $companyMicrolearningExtendUserInstitutionMapper->insert($record);
1214
                        }
1 www 1215
 
4 efrain 1216
                        if($record->id) {
1217
                            $extendUser->extend_institution_id = $record->id;
1218
                        }
1219
                    }
1 www 1220
 
15452 efrain 1221
                    if($program) {
1222
                        $record = $companyMicrolearningExtendUserProgramMapper->fetchOneByCompanyIdAndName($currentCompany->id, $program);
4 efrain 1223
                        if(!$record) {
1224
                            $record = new CompanyMicrolearningExtendUserProgram();
1225
                            $record->company_id = $currentCompany->id;
15452 efrain 1226
                            $record->name = $program;
1 www 1227
 
4 efrain 1228
                            $companyMicrolearningExtendUserProgramMapper->insert($record);
1229
                        }
1 www 1230
 
4 efrain 1231
                        if($record->id) {
1232
                            $extendUser->extend_program_id = $record->id;
1233
                        }
1234
                    }
1 www 1235
 
15452 efrain 1236
                    if($partner) {
4 efrain 1237
 
1238
 
15452 efrain 1239
                        $record = $companyMicrolearningExtendUserPartnerMapper->fetchOneByCompanyIdAndName($currentCompany->id, $partner);
4 efrain 1240
                        if(!$record) {
1241
                            $record = new CompanyMicrolearningExtendUserPartner();
1242
                            $record->company_id = $currentCompany->id;
15452 efrain 1243
                            $record->name = $partner;
1 www 1244
 
4 efrain 1245
                            $companyMicrolearningExtendUserPartnerMapper->insert($record);
1246
                        }
1 www 1247
 
4 efrain 1248
                        if($record->id) {
1249
                            $extendUser->extend_partner_id = $record->id;
1250
                        }
1251
                    }
1 www 1252
 
15452 efrain 1253
                    if($sector) {
1254
                        $record = $companyMicrolearningExtendUserSectorMapper->fetchOneByCompanyIdAndName($currentCompany->id, $sector);
4 efrain 1255
                        if(!$record) {
1256
                            $record = new CompanyMicrolearningExtendUserSector();
1257
                            $record->company_id = $currentCompany->id;
15452 efrain 1258
                            $record->name = $sector;
1 www 1259
 
4 efrain 1260
                            $companyMicrolearningExtendUserSectorMapper->insert($record);
1261
                        }
1 www 1262
 
4 efrain 1263
                        if($record->id) {
1264
                            $extendUser->extend_sector_id = $record->id;
1265
                        }
1266
                    }
1 www 1267
 
15452 efrain 1268
                    if($studentType) {
1269
                        $record = $companyMicrolearningExtendUserStudentTypeMapper->fetchOneByCompanyIdAndName($currentCompany->id, $studentType);
4 efrain 1270
                        if(!$record) {
1271
                            $record = new CompanyMicrolearningExtendUserStudentType();
1272
                            $record->company_id = $currentCompany->id;
15452 efrain 1273
                            $record->name = $studentType;
1 www 1274
 
4 efrain 1275
                            $companyMicrolearningExtendUserStudentTypeMapper->insert($record);
1276
                        }
1277
                        if($record->id) {
1278
                            $extendUser->extend_student_type_id = $record->id;
1279
                        }
1280
                    }
1281
 
15452 efrain 1282
                    if($country) {
1283
                        $record = $companyMicrolearningExtendUserCountryMapper->fetchOneByCompanyIdAndName($currentCompany->id, $country);
1284
                        if(!$record) {
1285
                            $record = new CompanyMicrolearningExtendUserCountry();
1286
                            $record->company_id = $currentCompany->id;
1287
                            $record->name = $country;
1288
 
1289
                            $companyMicrolearningExtendUserCountryMapper->insert($record);
1290
                        }
1291
                        if($record->id) {
1292
                            $extendUser->extend_country_id = $record->id;
1293
                        }
1294
                    }
4 efrain 1295
 
1296
 
15452 efrain 1297
 
1298
 
1 www 1299
 
4 efrain 1300
                    if($extendUser->id) {
1301
                       $result =   $companyMicrolearningExtendUserMapper->update($extendUser);
1302
                    } else {
1303
                       $result = $companyMicrolearningExtendUserMapper->insert($extendUser);
1304
                    }
1305
 
1306
 
1307
 
1 www 1308
                }
1309
 
17000 efrain 1310
                $notificationMapper = NotificationMapper::getInstance($this->adapter);
4 efrain 1311
 
16998 efrain 1312
 
15457 efrain 1313
                $users_processed = 0;
1314
                $users_previous = 0;
1 www 1315
                foreach($user_ids as $user_id)
1316
                {
16983 efrain 1317
                    $user = $userMapper->fetchOne($user_id);
1318
                    $first_name = $user->first_name;
1319
                    $last_name = $user->last_name;
1320
                    $email = $user->email;
15457 efrain 1321
 
16983 efrain 1322
 
15457 efrain 1323
                    $users_processed++;
1 www 1324
                    $capsuleUser = $capsuleUserMapper->fetchOneByUserIdAndCapsuleId($user_id, $capsule->id);
15457 efrain 1325
                    if($capsuleUser) {
1326
                        $users_previous++;
16983 efrain 1327
                        $csv .= "$first_name|$last_name|$email|PREVIOUS FOUND \r\n";
15457 efrain 1328
                    } else {
1 www 1329
                        $capsuleUser = new CompanyMicrolearningCapsuleUser();
1330
                        $capsuleUser->company_id = $capsule->company_id;
1331
                        $capsuleUser->topic_id = $capsule->topic_id;
1332
                        $capsuleUser->capsule_id = $capsule->id;
1333
                        $capsuleUser->user_id = $user_id;
1334
                        $capsuleUser->access = CompanyMicrolearningCapsuleUser::ACCESS_UNLIMITED;
1335
 
1336
                        if($capsuleUserMapper->insert($capsuleUser)) {
16998 efrain 1337
 
1338
                            $notification = new Notification();
1339
                            $notification->company_id = $capsule->company_id;
1340
                            $notification->user_id = $user_id;
1341
                            $notification->topic_id = $capsule->topic_id;
1342
                            $notification->capsule_id = $capsule->id;
1343
                            $notification->type = Notification::TYPE_NEW_MICROLEARNING_CAPSULE;
17001 efrain 1344
                            $notification->message  = 'LABEL_NOTIFICATION_NEW_MICROLEARNING_CAPSULE' . ' : ' . $capsule->name;
16998 efrain 1345
                            $notification->url      = '/microlearning/capsules/' . $capsule->uuid .  '/detail';
1346
 
1347
                            $notificationMapper->insert($notification);
1348
 
1349
 
16983 efrain 1350
                            $csv .= "$first_name|$last_name|$email|CAPSULE USER ASSIGNED\r\n";
1 www 1351
                            $users_assigned++;
1352
 
1353
 
1354
                            $capsuleUser = $capsuleUserMapper->fetchOne($capsuleUser->id);
1355
                            if($capsuleUser) {
1356
                                $companyMicrolearningUserMapper = CompanyMicrolearningUserMapper::getInstance($this->adapter);
1357
                                $companyMicrolearningUser = $companyMicrolearningUserMapper->fetchOneByUserIdAndCompanyId($capsuleUser->user_id, $capsuleUser->company_id);
1358
                                if($companyMicrolearningUser) {
1359
                                    $companyMicrolearningUser->updated_on = $capsuleUser->updated_on;
1360
 
1361
                                    $companyMicrolearningUserMapper->update($companyMicrolearningUser);
1362
 
1363
                                } else {
1364
                                    $companyMicrolearningUser = new CompanyMicrolearningUser();
1365
                                    $companyMicrolearningUser->company_id = $capsuleUser->company_id;
1366
                                    $companyMicrolearningUser->user_id = $capsuleUser->user_id;
1367
                                    $companyMicrolearningUser->added_on = $capsuleUser->added_on;
1368
                                    $companyMicrolearningUser->updated_on = $capsuleUser->updated_on;
1369
 
1370
                                    $companyMicrolearningUserMapper->insert($companyMicrolearningUser);
1371
                                }
1372
                            }
16983 efrain 1373
                        } else {
1374
                            $csv .= "$first_name|$last_name|$email|CAPSULE USER PREVIOUS \r\n";
1 www 1375
                        }
1376
 
1377
                    }
1378
 
1379
 
1380
 
1381
                }
1382
 
15457 efrain 1383
                $users_in_the_capsule = $capsuleUserMapper->fetchCountByCompanyIdAndTopicIdAndCapsuleId($capsule->company_id, $capsule->topic_id, $capsule->id);
1384
 
1 www 1385
                return new JsonModel([
1386
                    'success' => true,
1387
                    'data' => [
15457 efrain 1388
                        'users_assigned' => $users_assigned,
1389
                        'users_processed' => $users_processed,
1390
                        'users_in_the_capsule' => $users_in_the_capsule,
16983 efrain 1391
                        'users_previous' => $users_previous,
1392
                        'csv_base64_content' => base64_encode($csv),
1393
                        'csv_filename' => 'capsule-users-' .date('Y-m-d-h-i-s').  '.csv'
1 www 1394
                    ]
1395
                ]);
1396
 
1397
 
1398
 
1399
 
1400
            } else {
1401
                return new JsonModel([
1402
                    'success' => false,
1403
                    'data' => 'ERROR_PARAMETERS_ARE_INVALID'
1404
                ]);
1405
            }
1406
 
1407
 
1408
 
1409
 
1410
        }
1411
 
1412
        return new JsonModel([
1413
            'success' => false,
1414
            'data' => 'ERROR_METHOD_NOT_ALLOWED'
1415
        ]);
1416
    }
1417
 
1418
    public function notificationAction()
1419
    {
1420
        $request = $this->getRequest();
1421
 
1422
        $currentUserPlugin = $this->plugin('currentUserPlugin');
1423
        $currentUser    = $currentUserPlugin->getUser();
1424
        $currentCompany = $currentUserPlugin->getCompany();
1425
 
1426
        $request    = $this->getRequest();
1427
        $topic_uuid     = $this->params()->fromRoute('topic_uuid');
1428
        $capsule_uuid   = $this->params()->fromRoute('capsule_uuid');
1429
 
1430
 
1431
        $topicMapper = CompanyMicrolearningTopicMapper::getInstance($this->adapter);
1432
        $topic = $topicMapper->fetchOneByUuid($topic_uuid);
1433
        if(!$topic) {
1434
            return new JsonModel([
1435
                'success'   => false,
1436
                'data'   => 'ERROR_TOPIC_NOT_FOUND'
1437
            ]);
1438
        }
1439
 
1440
 
1441
 
1442
        if($topic->company_id != $currentCompany->id) {
1443
            return new JsonModel([
1444
                'success'   => false,
1445
                'data'   => 'ERROR_UNAUTHORIZED'
1446
            ]);
1447
        }
1448
 
1449
        $capsuleMapper = CompanyMicrolearningCapsuleMapper::getInstance($this->adapter);
1450
        $capsule = $capsuleMapper->fetchOneByUuid($capsule_uuid);
1451
        if(!$capsule) {
1452
            return new JsonModel([
1453
                'success'   => false,
1454
                'data'   => 'ERROR_CAPSULE_NOT_FOUND'
1455
            ]);
1456
        }
1457
 
1458
 
1459
        if($capsule->topic_id != $topic->id) {
1460
            return new JsonModel([
1461
                'success'   => false,
1462
                'data'   => 'ERROR_UNAUTHORIZED'
1463
            ]);
1464
        }
1465
 
1466
 
1467
        if($request->isPost()) {
1468
            $dataPost = $request->getPost()->toArray();
15390 efrain 1469
            $form = new PushMicrolearningNotificationForm($this->adapter, $currentCompany->id);
1 www 1470
 
1471
            $form->setData($dataPost);
1472
 
1473
            if($form->isValid()) {
1474
                $customer_uuids = $this->params()->fromPost('customer_uuids');
1475
                if(!$customer_uuids) {
1476
                    return new JsonModel([
1477
                        'success' => false,
1478
                        'data' => 'ERROR_NOT_SELECTED_CUSTOMERS'
1479
                    ]);
1480
 
1481
                }
1482
 
16766 efrain 1483
                $push_template_uuid = Functions::sanitizeFilterString($form->get('push_template_id')->getValue());
1 www 1484
                $pushMapper = PushMapper::getInstance($this->adapter);
1485
                $pushTemplateMapper = PushTemplateMapper::getInstance($this->adapter);
1486
                $pushTemplate = $pushTemplateMapper->fetchOneByUuid($push_template_uuid);
1487
 
1488
                if(!$pushTemplate) {
1489
                    return new JsonModel([
1490
                        'success' => false,
1491
                        'data' => 'ERROR_PUSH_TEMPLATE_NOT_FOUND'
1492
                    ]);
1493
                }
1494
 
1495
 
1496
 
1497
                $applicationMapper = ApplicationMapper::getInstance($this->adapter);
1498
                $application = $applicationMapper->fetchOne(Application::TWOGETSKILLS);
1499
 
1500
                $capsuleUserMapper = CompanyMicrolearningCapsuleUserMapper::getInstance($this->adapter);
1501
 
1502
                $push_to_send = 0;
1503
 
1504
 
1505
 
1506
                $userMapper = UserMapper::getInstance($this->adapter);
1507
                $deviceHistoryMapper = DeviceHistoryMapper::getInstance($this->adapter);
1508
                foreach($customer_uuids as $customer_uuid)
1509
                {
1510
 
1511
 
1512
                    $user = $userMapper->fetchOneByUuid($customer_uuid);
1513
                    if(!$user) {
1514
                        continue;
1515
                    }
1516
 
1517
                    $capsuleUser = $capsuleUserMapper->fetchOneByUserIdAndCapsuleId($user->id, $capsule->id);
1518
                    if(!$capsuleUser) {
1519
                        continue;
1520
                    }
1521
 
1522
 
13755 efrain 1523
                    //$token = $deviceHistoryMapper->fetchLastDeviceTokenByApplicationIdAndUserId(Application::TWOGETSKILLS, $user->id);
1524
                    $device = $deviceHistoryMapper->fetchLastDeviceByApplicationIdAndUserId(Application::TWOGETSKILLS, $user->id);
1 www 1525
 
13755 efrain 1526
 
1527
 
1528
                    if($device && $device->token) {
1529
 
1530
                        $key = $application->key;
1531
                        if($device->variant_id) {
1532
 
1533
                            $applicationVariantMapper = ApplicationVariantMapper::getInstance($this->adapter);
1534
                            $applicationVariant = $applicationVariantMapper->fetchOneByApplicationIdAndVariantId($device->application_id, $device->variant_id);
1535
                            if($applicationVariant) {
1536
                                $key = $applicationVariant->key;
1537
                            } else {
1538
                                $applicationVariant = $applicationVariantMapper->fetchOneByApplicationIdAndDefault($device->application_id);
1539
                                if($applicationVariant) {
1540
                                    $key = $applicationVariant->key;
1541
                                }
1542
                            }
1543
 
1544
                        }
1545
 
1 www 1546
                        $push = new Push();
1547
                        $push->status = Push::STATUS_PENDING;
1548
                        $push->data = json_encode([
1549
                            'server' => [
13755 efrain 1550
                                'key' => $key,
1 www 1551
                            ],
1552
                            'push' => [
1553
                                'registration_ids'   => [
13755 efrain 1554
                                    $device->token,
1 www 1555
                                ],
1556
                                'notification' => [
1557
                                    'body' =>  $pushTemplate->body,
1558
                                    'title' => $pushTemplate->title,
1559
                                    'vibrate' => 1,
1560
                                    'sound' =>  1
1561
                                ],
1671 efrain 1562
                                'data' => [
10435 efrain 1563
                                    'command' => 'content-refresh',
1564
                                    'new_capsules' => '0',
1671 efrain 1565
                                ]
1 www 1566
                            ]
1567
                        ]);
1568
 
1569
                        if($pushMapper->insert($push)) {
1570
                            $push_to_send = $push_to_send + 1;
1571
                        }
1572
 
1573
                    }
1574
                }
1575
 
1576
                if(0 == $push_to_send) {
1577
                    return new JsonModel([
1578
                        'success' => false,
1579
                        'data' => 'ERROR_NO_USER_DEVICES_WERE_FOUND_TO_SEND_PUSH'
1580
                    ]);
1581
                }
1582
 
1583
 
1584
 
1585
 
1586
 
1587
                return new JsonModel([
1588
                    'success' => true,
1589
                    'data' => [
1590
                        'push_to_send' => $push_to_send,
1591
                    ]
1592
                ]);
1593
 
1594
 
1595
 
1596
 
1597
 
1598
            } else {
1599
 
1600
                $messages = [];
1601
                $form_messages = (array) $form->getMessages();
1602
                foreach($form_messages  as $fieldname => $field_messages)
1603
                {
1604
                    $messages[$fieldname] = array_values($field_messages);
1605
                }
1606
 
1607
                return new JsonModel([
1608
                    'success'   => false,
1609
                    'data'      => $messages
1610
                ]);
1611
            }
1612
        }
1613
 
1614
        return new JsonModel([
1615
            'success' => false,
1616
            'data' => 'ERROR_METHOD_NOT_ALLOWED'
1617
        ]);
1618
    }
1619
 
1620
 
1621
}