Proyectos de Subversion LeadersLinked - Antes de SPA

Rev

Rev 222 | Rev 224 | 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
 
7
use Laminas\Authentication\AuthenticationService;
8
use Laminas\Authentication\Result as AuthResult;
9
use Laminas\Db\Adapter\AdapterInterface;
10
use Laminas\Cache\Storage\Adapter\AbstractAdapter;
11
use Laminas\Mvc\Controller\AbstractActionController;
12
use Laminas\Log\LoggerInterface;
13
use Laminas\View\Model\JsonModel;
14
 
15
use LeadersLinked\Authentication\AuthAdapter;
16
use LeadersLinked\Mapper\UserMapper;
17
use LeadersLinked\Mapper\EmailTemplateMapper;
18
use LeadersLinked\Model\User;
19
use LeadersLinked\Model\UserType;
20
 
219 efrain 21
use LeadersLinked\Library\AesCipher;
1 www 22
use LeadersLinked\Library\QueueEmail;
23
use LeadersLinked\Library\Functions;
24
use LeadersLinked\Model\EmailTemplate;
25
use LeadersLinked\Mapper\UserPasswordMapper;
26
use LeadersLinked\Mapper\DeviceMapper;
27
use LeadersLinked\Model\Device;
28
use LeadersLinked\Mapper\ApplicationMapper;
29
use LeadersLinked\Model\Application;
30
use LeadersLinked\Validator\PasswordStrengthCheck;
31
 
32
use LeadersLinked\Mapper\CompanyMapper;
33
use LeadersLinked\Model\Company;
34
use LeadersLinked\Mapper\CompanyMicrolearningTopicMapper;
35
use LeadersLinked\Mapper\CompanyMicrolearningCapsuleMapper;
36
use LeadersLinked\Mapper\CompanyMicrolearningSlideMapper;
37
use LeadersLinked\Model\CompanyMicrolearningSlide;
38
use LeadersLinked\Mapper\CompanyMicrolearningUserLogMapper;
39
use LeadersLinked\Mapper\CompanyMicrolearningUserProgressMapper;
40
use LeadersLinked\Mapper\CompanyMicrolearningQuizMapper;
41
use LeadersLinked\Mapper\CompanyMicrolearningQuestionMapper;
42
use LeadersLinked\Mapper\CompanyMicrolearningAnswerMapper;
43
use LeadersLinked\Model\CompanyMicrolearningUserProgress;
44
use LeadersLinked\Model\CompanyMicrolearningUserLog;
45
use LeadersLinked\Mapper\DeviceHistoryMapper;
46
use LeadersLinked\Model\DeviceHistory;
47
use LeadersLinked\Mapper\PushMapper;
48
use LeadersLinked\Model\Push;
49
use LeadersLinked\Mapper\CompanyMicrolearningCapsuleUserMapper;
50
use LeadersLinked\Mapper\CompanyServiceMapper;
51
use LeadersLinked\Model\Service;
52
use LeadersLinked\Model\CompanyService;
53
use LeadersLinked\Model\CompanyMicrolearningCapsuleUser;
54
use LeadersLinked\Model\CompanyMicrolearningUserQuiz;
55
use LeadersLinked\Mapper\CompanyMicrolearningUserQuizMapper;
56
use LeadersLinked\Mapper\CompanyMicrolearningUserMapper;
57
use LeadersLinked\Model\CompanyMicrolearningUser;
58
use LeadersLinked\Mapper\PushTemplateMapper;
59
use LeadersLinked\Model\PushTemplate;
41 efrain 60
use LeadersLinked\Mapper\SyncLogMapper;
61
use LeadersLinked\Model\SyncLog;
47 efrain 62
use LeadersLinked\Model\CompanyMicrolearningExtendUser;
63
use LeadersLinked\Mapper\CompanyMicrolearningExtendUserMapper;
64
use LeadersLinked\Model\CompanyMicrolearningExtendUserCompany;
65
use LeadersLinked\Mapper\CompanyMicrolearningExtendUserCompanyMapper;
66
use LeadersLinked\Mapper\CompanyMicrolearningExtendUserFunctionMapper;
67
use LeadersLinked\Mapper\CompanyMicrolearningExtendUserGroupMapper;
68
use LeadersLinked\Mapper\CompanyMicrolearningExtendUserInstitutionMapper;
69
use LeadersLinked\Mapper\CompanyMicrolearningExtendUserPartnerMapper;
70
use LeadersLinked\Mapper\CompanyMicrolearningExtendUserProgramMapper;
71
use LeadersLinked\Mapper\CompanyMicrolearningExtendUserStudentTypeMapper;
72
use LeadersLinked\Mapper\CompanyMicrolearningExtendUserSectorMapper;
219 efrain 73
use Nullix\CryptoJsAes\CryptoJsAes;
1 www 74
 
75
 
76
class ServiceController extends AbstractActionController
77
{
78
 
79
 
80
    /**
81
     *
82
     * @var AdapterInterface
83
     */
84
    private $adapter;
85
 
86
 
87
    /**
88
     *
89
     * @var AbstractAdapter
90
     */
91
    private $cache;
92
 
93
    /**
94
     *
95
     * @var  LoggerInterface
96
     */
97
    private $logger;
98
 
99
    /**
100
     *
101
     * @var array
102
     */
103
    private $config;
104
 
105
    /**
106
     *
107
     * @param AdapterInterface $adapter
108
     * @param AbstractAdapter $cache
109
     * @param LoggerInterface $logger
110
     * @param array $config
111
     */
112
    public function __construct($adapter, $cache , $logger, $config)
113
    {
114
        $this->adapter      = $adapter;
115
        $this->cache        = $cache;
116
        $this->logger       = $logger;
117
        $this->config       = $config;
118
    }
119
 
112 efrain 120
    public function indexAction()
121
    {
122
        return new JsonModel(['ok' => false]);
123
    }
124
 
1 www 125
    public function signoutAction()
126
    {
127
        $currentUser = $this->plugin('currentUserPlugin');
128
        if($currentUser->hasIdentity()) {
129
            $device_uuid = $currentUser->getDeviceId();
130
            if($device_uuid) {
131
                $deviceMapper = DeviceMapper::getInstance($this->adapter);
132
                $device = $deviceMapper->fetchOne($device_uuid);
133
                if($device) {
134
                    $deviceMapper->signout($device);
135
                }
136
            }
137
 
138
 
139
            $this->logger->info('Desconexión del mobile', ['user_id' => $currentUser->getUserId(), 'ip' => Functions::getUserIP()]);
140
        }
141
        $authService = new \Laminas\Authentication\AuthenticationService();
142
        $authService->clearIdentity();
143
 
144
        return new JsonModel([
145
            'success' => true,
146
            'data' => 'LABEL_SIGNOUT_SUCCESSFULL'
147
        ]);
148
    }
149
 
150
    public function fcmAction()
151
    {
152
        $request = $this->getRequest();
153
 
154
        if($request->isPost()) {
155
 
43 efrain 156
            //$rawdata = file_get_contents("php://input");
157
            //error_log('$rawdata = ' . $rawdata );
1 www 158
 
159
            $device_uuid      = filter_var($this->params()->fromPost('device_uuid', ''), FILTER_SANITIZE_STRING);
160
            $token          = filter_var($this->params()->fromPost('token', ''), FILTER_SANITIZE_STRING);
161
            $sync_id        = filter_var($this->params()->fromPost('sync_id', ''), FILTER_SANITIZE_NUMBER_INT);
162
 
163
            /*
164
            echo '$device_uuid = ' . $device_uuid .PHP_EOL;
165
            echo '$token = ' . $token .PHP_EOL;
166
            echo '$sync_id  = ' . $sync_id  .PHP_EOL;
167
            */
168
            $ok = $device_uuid && strlen($device_uuid) == 36 && $sync_id;
169
            $ok = $ok && strlen($token) <= 512;
170
 
171
 
172
            if(!$ok) {
173
                return new JsonModel([
174
                    'success' => false,
175
                    'data' => 'ERROR_PARAMETERS_ARE_INVALID',
176
                ]);
177
            }
178
 
179
            $deviceMapper = DeviceMapper::getInstance($this->adapter);
180
            $device = $deviceMapper->fetchOne($device_uuid);
181
            if(!$device) {
182
                return new JsonModel([
183
                    'success' => false,
184
                    'data' => 'ERROR_DEVICE_NOT_FOUND',
185
                ]);
186
            }
187
 
188
 
189
            $applicationMapper = ApplicationMapper::getInstance($this->adapter);
190
            $application = $applicationMapper->fetchOne($device->application_id);
191
            if(!$application) {
192
                return new JsonModel([
193
                    'success' => false,
194
                    'data' => 'ERROR_APPLICATION_NOT_FOUND',
195
                ]);
196
            }
197
 
198
            if($application->status == Application::STATUS_INACTIVE) {
199
                return new JsonModel([
200
                    'success' => false,
201
                    'data' => 'ERROR_APPLICATION_IS_INACTIVE',
202
                ]);
203
            }
204
 
41 efrain 205
 
206
            $syncLog = new SyncLog();
46 efrain 207
            $syncLog->data = json_encode(['token' => $token]);
41 efrain 208
            $syncLog->type = 'token';
209
            $syncLog->device_uuid = $device->id;
210
            $syncLog->ip = Functions::getUserIP();
211
 
212
            $syncLogMapper = SyncLogMapper::getInstance($this->adapter);
213
            $syncLogMapper->insert($syncLog);
214
 
1 www 215
            $device->token = $token;
216
            $device->ip = Functions::getUserIP();
217
            $result = $deviceMapper->update($device);
218
 
219
 
220
            if($result) {
221
                return new JsonModel([
222
                    'success' => true,
223
                    'data' => [
224
                        'sync_id' => $sync_id
225
                    ]
226
                ]);
227
            } else {
228
                return new JsonModel([
229
                    'success' => false,
230
                    'data' => 'ERROR_THERE_WAS_AN_ERROR',
231
                ]);
232
            }
233
 
234
        }
235
 
236
        return new JsonModel([
237
            'success' => false,
238
            'data' => 'ERROR_METHOD_NOT_ALLOWED'
239
        ]);
240
    }
241
 
242
    public function checkSessionAction()
243
    {
244
        $request = $this->getRequest();
245
 
246
        if($request->isPost()) {
247
            $device_uuid  = trim(filter_var($this->params()->fromPost('device_id', ''), FILTER_SANITIZE_STRING));
248
            $secret     = trim(filter_var($this->params()->fromPost('secret', ''), FILTER_SANITIZE_STRING));
249
            $rand       = filter_var($this->params()->fromPost('rand', ''), FILTER_SANITIZE_NUMBER_INT);
250
            $created    = trim(filter_var($this->params()->fromPost('created', ''), FILTER_SANITIZE_STRING));
251
 
252
            if(!$device_uuid || !$secret || !$rand || !$created) {
253
                return new JsonModel([
254
                    'success' => false,
255
                    'data' => 'ERROR_PARAMETERS_ARE_INVALID'
256
                ]);
257
            }
258
 
259
            $dt = \DateTime::createFromFormat('Y-m-d\TH:i:s',  $created);
260
            if(!$dt) {
261
                return new JsonModel([
262
                    'success' => false,
263
                    'data' => 'ERROR_PARAMETERS_ARE_INCORRECTLY_FORMATTED'
264
                ]);
265
            }
266
 
267
 
268
            $deviceMapper = DeviceMapper::getInstance($this->adapter);
269
            $device = $deviceMapper->fetchOne($device_uuid);
270
            if(!$device) {
271
                return new JsonModel([
272
                    'success' => false,
273
                    'data' => 'ERROR_DEVICE_NOT_FOUND'
274
                ]);
275
            }
276
 
277
 
278
            $passworVerification = md5($device->password . ':' . $created . ':'  . $rand);
279
            if($secret != $passworVerification) {
280
                return new JsonModel([
281
                    'success' => false,
282
                    'data' => 'ERROR_WEBSERVICE_PASSWORD'
283
                ]);
284
            }
285
 
286
 
287
            $userMapper = UserMapper::getInstance($this->adapter);
288
            $user = $userMapper->fetchOne($device->user_id);
289
 
290
            if(User::BLOCKED_YES == $user->blocked) {
291
                return new JsonModel([
292
                    'success' => false,
293
                    'data' => 'ERROR_USER_IS_BLOCKED'
294
                ]);
295
            }
296
 
297
            if(User::STATUS_INACTIVE == $user->status) {
298
                return new JsonModel([
299
                    'success' => false,
300
                    'data' =>'ERROR_USER_IS_INACTIVE'
301
                ]);
302
            }
303
 
304
 
305
            return new JsonModel([
306
                'success' => true,
307
                'data' => [
308
                    'user_uuid' => $device->user_uuid
309
                ]
310
            ]);
311
 
312
        }
313
 
314
        return new JsonModel([
315
            'success' => false,
316
            'data' => 'ERROR_METHOD_NOT_ALLOWED'
317
        ]);
318
    }
319
 
320
    public function deviceAction()
321
    {
322
 
43 efrain 323
        //$rawdata = file_get_contents("php://input");
324
        //error_log('$rawdata = ' . $rawdata );
1 www 325
 
326
        $request = $this->getRequest();
327
 
328
        if($request->isPost()) {
329
            //print_r($_POST);
330
 
331
 
332
            $application_id = filter_var($this->params()->fromPost('application_id', 0), FILTER_SANITIZE_NUMBER_INT);
333
            $device_uuid    = filter_var($this->params()->fromPost('device_uuid', ''), FILTER_SANITIZE_STRING);
334
            $manufacturer   = filter_var($this->params()->fromPost('manufacturer', ''), FILTER_SANITIZE_STRING);
335
            $platform       = filter_var($this->params()->fromPost('platform', ''), FILTER_SANITIZE_STRING);
336
            $brand          = filter_var($this->params()->fromPost('brand', ''), FILTER_SANITIZE_STRING);
337
            $version        = filter_var($this->params()->fromPost('version', ''), FILTER_SANITIZE_STRING);
338
            $model          = filter_var($this->params()->fromPost('model', ''), FILTER_SANITIZE_STRING);
339
            $sync_id        = filter_var($this->params()->fromPost('sync_id', ''), FILTER_SANITIZE_NUMBER_INT);
340
 
341
            $ok = $application_id && $device_uuid && strlen($device_uuid) == 36 && $sync_id;
342
            $ok = $ok && strlen($manufacturer) <= 250;
343
            $ok = $ok && strlen($brand) <= 250;
344
            $ok = $ok && strlen($version) <= 250;
345
            $ok = $ok && strlen($model) <= 250;
346
 
347
            if(!$ok) {
348
                return new JsonModel([
349
                    'success' => false,
350
                    'data' => 'ERROR_PARAMETERS_ARE_INVALID',
351
                ]);
352
            }
353
 
354
 
355
            $applicationMapper = ApplicationMapper::getInstance($this->adapter);
356
            $application = $applicationMapper->fetchOne($application_id);
357
            if(!$application) {
358
                return new JsonModel([
359
                    'success' => false,
360
                    'data' => 'ERROR_APPLICATION_NOT_FOUND',
361
                ]);
362
            }
363
 
364
            if($application->status == Application::STATUS_INACTIVE) {
365
                return new JsonModel([
366
                    'success' => false,
367
                    'data' => 'ERROR_APPLICATION_IS_INACTIVE',
368
                ]);
369
            }
370
 
41 efrain 371
 
372
            $syncLog = new SyncLog();
373
            $syncLog->data = json_encode([
374
                'platform' => $platform,
375
                'manufacturer' => $manufacturer,
376
                'brand' => $brand,
377
                'version' => $version,
378
                'model' => $model,
379
            ]);
380
            $syncLog->type = 'device';
381
            $syncLog->device_uuid = $device_uuid;
382
            $syncLog->ip = Functions::getUserIP();
383
 
384
            $syncLogMapper = SyncLogMapper::getInstance($this->adapter);
385
            $syncLogMapper->insert($syncLog);
386
 
387
 
1 www 388
            $deviceMapper = DeviceMapper::getInstance($this->adapter);
389
            $device = $deviceMapper->fetchOne($device_uuid);
390
 
391
 
392
 
393
 
394
            if($device) {
395
                $device->platform       = $platform;
396
                $device->manufacturer   = $manufacturer;
397
                $device->brand          = $brand;
398
                $device->version        = $version;
399
                $device->model          = $model;
400
                $device->ip             = Functions::getUserIP();
401
                $result                 = $deviceMapper->update($device);
402
 
403
            } else {
404
                $device                 = new Device();
405
                $device->id             = $device_uuid;
406
                $device->application_id = $application->id;
407
                $device->manufacturer   = $manufacturer;
408
                $device->brand          = $brand;
409
                $device->version        = $version;
410
                $device->model          = $model;
411
                $device->platform       = $platform;
412
                $device->ip             = Functions::getUserIP();
413
                $device->aes            = Functions::generatePassword(16);
414
                $device->password       = Functions::generatePassword(32);
415
                $result                 = $deviceMapper->insert($device);
416
            }
417
 
418
 
419
 
420
            if($result) {
421
                return new JsonModel([
422
                    'success' => true,
423
                    'data' => [
424
                        'sync_id'   => $sync_id,
425
                        'aes'       => $device->aes,
426
                        'password'  => $device->password,
427
                    ]
428
                ]);
429
            } else {
430
                return new JsonModel([
431
                    'success' => false,
432
                    'data' => 'ERROR_THERE_WAS_AN_ERROR',
433
                ]);
434
            }
435
 
436
        }
437
 
438
        return new JsonModel([
439
            'success' => false,
440
            'data' => 'ERROR_METHOD_NOT_ALLOWED'
441
        ]);
442
 
443
    }
444
 
445
    public function microlearningCheckChangesAction()
446
    {
447
        $request = $this->getRequest();
448
 
449
        if($request->isPost()) {
450
            $currentUserPlugin = $this->plugin('currentUserPlugin');
451
            $user = $currentUserPlugin->getUser();
452
 
113 efrain 453
            /*
112 efrain 454
            $rawdata = file_get_contents("php://input");
455
            error_log('url = ' . $_SERVER['REQUEST_URI']);
456
            error_log('query = ' . $_SERVER['QUERY_STRING']);
457
            error_log('$rawdata = ' . $rawdata );
113 efrain 458
            */
1 www 459
 
460
            $serviceDatetimeFormat = $this->config['leaderslinked.services.datetime'];
461
 
462
 
463
            $device_uuid        = filter_var($this->params()->fromPost('device_uuid', ''), FILTER_SANITIZE_STRING);
464
            $max_date_changes   = filter_var($this->params()->fromPost('max_date_changes', ''), FILTER_SANITIZE_STRING);
112 efrain 465
            $max_ids            = filter_var($this->params()->fromPost('max_ids', 0), FILTER_SANITIZE_NUMBER_INT);
466
            $is_foreground      = filter_var($this->params()->fromPost('is_foreground', 0), FILTER_SANITIZE_NUMBER_INT);
1 www 467
 
468
            $ids = [];
469
            for($i = 1; $i <= $max_ids; $i++)
470
            {
471
                $id = filter_var($this->params()->fromPost('id_' . $i, ''), FILTER_SANITIZE_STRING);
472
                if(empty($id)) {
473
                    continue;
474
                }
475
 
476
                $pattern = '/[A-Za-z0-9\-]+\|[A-Za-z0-9\-]+/';
477
                $matches = [];  preg_match($pattern, $id, $matches, PREG_OFFSET_CAPTURE);
478
                if(count($matches) > 1) {
479
                    array_push($ids, $matches[0]);
480
                }
481
 
482
            }
483
 
112 efrain 484
            if(empty($ids)) {
485
                $max_date_changes = '';
486
            }  else {
1 www 487
 
488
 
112 efrain 489
                if($max_date_changes) {
490
                    $dt = \DateTime::createFromFormat($serviceDatetimeFormat, $max_date_changes);
491
                    if($dt) {
492
                      $max_date_changes = $dt->format('Y-m-d H:i:s');
493
                    } else {
494
                        $max_date_changes = '';
495
                    }
1 www 496
                } else {
497
                    $max_date_changes = '';
112 efrain 498
                }
499
            }
1 www 500
 
501
 
112 efrain 502
 
43 efrain 503
            //error_log('device_uuid = ' . $device_uuid . ' max_date_changes = ' . $max_date_changes);
1 www 504
 
505
            $ok = $device_uuid && strlen($device_uuid);
506
 
507
            if(!$ok) {
508
                return new JsonModel([
509
                    'success' => false,
510
                    'data' => 'ERROR_PARAMETERS_ARE_INVALID',
511
                ]);
512
            }
513
 
514
            $deviceMapper = DeviceMapper::getInstance($this->adapter);
515
            $device = $deviceMapper->fetchOne($device_uuid);
516
 
517
 
518
            if(!$device) {
519
                return new JsonModel([
520
                    'success' => false,
521
                    'data' => 'ERROR_DEVICE_NOT_FOUND'
522
                ]);
523
            } else {
524
                $device->ip = Functions::getUserIP();
525
                $deviceMapper->update($device);
526
            }
527
 
528
            //Cargamos la fecha máxima del cambio
529
            $companyMicrolearningUserMapper = CompanyMicrolearningUserMapper::getInstance($this->adapter);
530
            $max_date_changes_db = $companyMicrolearningUserMapper->fetchMaxDateChanges($user->id);
531
 
112 efrain 532
 
533
 
534
 
1 www 535
            //Si la fecha es vacia agregamos la fecha máxima de la asignación de la capsula
536
            if(!$max_date_changes_db) {
537
                $companyUsers = [];
538
                $companyMicrolearningCapsuleUserMapper = CompanyMicrolearningCapsuleUserMapper::getInstance($this->adapter);
539
                $capsules = $companyMicrolearningCapsuleUserMapper->fetchAllActiveByUserId($user->id);
540
                foreach($capsules as $capsule)
541
                {
542
 
543
 
544
 
545
                    if(empty($companyUsers[$capsule->company_id])) {
546
                        $companyUsers[$capsule->company_id] = $capsule->updated_on;
547
                    } else {
548
 
549
                        if($capsule->updated_on > $companyUsers[$capsule->company_id]) {
550
                            $companyUsers[$capsule->company_id] = $capsule->updated_on;
551
                        }
552
 
553
                    }
554
 
555
                }
556
 
557
                $max_date_changes_db = '';
558
                foreach($companyUsers as $company_id => $update_on)
559
                {
560
 
561
                    $max_date_changes_db = $max_date_changes_db < $update_on ? $update_on : $max_date_changes_db;
562
 
563
                    $companyMicrolearningUser = new CompanyMicrolearningUser();
564
                    $companyMicrolearningUser->company_id = $company_id;
565
                    $companyMicrolearningUser->user_id = $user->id;
566
                    $companyMicrolearningUser->added_on = $update_on;
567
                    $companyMicrolearningUser->updated_on = $update_on;
568
 
569
                    $companyMicrolearningUserMapper->insert($companyMicrolearningUser);
570
                }
571
            }
572
 
112 efrain 573
            /*
574
            echo '$max_date_changes  = ' . $max_date_changes  . PHP_EOL;
575
            echo '$max_date_changes_db  = ' . $max_date_changes_db. PHP_EOL;
576
            exit;
577
            */
578
           // $max_date_changes = '';
1 www 579
 
43 efrain 580
 
1 www 581
            //Si la que tiene el dispositivo es diferente a la fecha máxima almacenada
582
            $newCapsules = 0;
583
            if($max_date_changes != $max_date_changes_db) {
584
                if(is_array($ids)) {
585
                    $companyMicrolearningTopicMapper = CompanyMicrolearningTopicMapper::getInstance($this->adapter);
586
                    $companyMicrolearningTopics = $companyMicrolearningTopicMapper->fetchAllActive();
587
 
588
                    $topics = [];
589
                    foreach($companyMicrolearningTopics as $topic)
590
                    {
591
                        $topics[$topic->id] = $topic->uuid;
592
                    }
593
 
594
                    $companyMicrolearningCapsuleMapper = CompanyMicrolearningCapsuleMapper::getInstance($this->adapter);
112 efrain 595
                    $companyMicrolearningCapsules = $companyMicrolearningCapsuleMapper->fetchAllActive();
1 www 596
 
597
                    $capsules = [];
598
                    foreach($companyMicrolearningCapsules as $capsule)
599
                    {
600
                        $capsules[$capsule->id] = $capsule->uuid;
601
                    }
602
 
603
                    $companyMicrolearningCapsuleUserMapper = CompanyMicrolearningCapsuleUserMapper::getInstance($this->adapter);
604
                    $user_capsules = $companyMicrolearningCapsuleUserMapper->fetchAllActiveByUserId($user->id);
605
 
112 efrain 606
 
607
                    //print_r($user_capsules);
608
 
1 www 609
                    foreach($user_capsules as $user_capsule)
610
                    {
611
                        $topic_uuid     = isset($topics[$user_capsule->topic_id]) ? $topics[$user_capsule->topic_id] : '';
612
                        $capsule_uuid   = isset($capsules[$user_capsule->capsule_id]) ?  $capsules[$user_capsule->capsule_id] : '';
613
 
614
                        if(!$topic_uuid || !$capsule_uuid) {
615
                            continue;
616
                        }
617
 
618
                        $key = $topic_uuid . '|' . $capsule_uuid;
112 efrain 619
                        //echo 'key =  ' . $key . PHP_EOL;
620
 
621
 
1 www 622
                        if(!in_array($key, $ids)) {
623
                            $newCapsules++;
624
                        }
625
                    }
626
                }
627
            }
628
 
112 efrain 629
            $dataSync = [];
630
 
1 www 631
            //echo 'Vamos a lanzar un PUSH' . PHP_EOL;
632
            if($newCapsules) {
633
 
112 efrain 634
 
635
                if($device->token && $is_foreground)
1 www 636
                {
637
 
638
                    $pushMapper = PushMapper::getInstance($this->adapter);
639
                    $pushTemplateMapper = PushTemplateMapper::getInstance($this->adapter);
640
                    $pushTemplate = $pushTemplateMapper->fetchOne(PushTemplate::ID_MICRO_LEARNING_NEW_CONTENT);
641
 
642
                    //echo 'PushTemplate' . PHP_EOL;
643
                    //print_r($pushTemplate);
644
 
645
                    $applicationMapper = ApplicationMapper::getInstance($this->adapter);
646
                    $application = $applicationMapper->fetchOne(Application::TWOGETSKILLS);
647
 
648
 
649
                    //echo 'Application';
650
                    //print_r($application);
651
                    if($pushTemplate && $application) {
652
                         $push = new Push();
653
                        $push->status = Push::STATUS_PENDING;
654
                        $push->data = json_encode([
655
                            'server' => [
656
                                'key' =>   $application->key,
657
                            ],
658
                            'push' => [
659
                                'registration_ids'   => [
660
                                    $device->token,
661
                                ],
662
                                'notification' => [
663
                                    'body' =>  $pushTemplate->body,
664
                                    'title' => $pushTemplate->title,
665
                                    'vibrate' => 1,
666
                                    'sound' =>  1,
667
 
668
 
669
                                ],
670
                                'data' => [
671
                                    'new_capsules' => $newCapsules,
672
                                ]
673
                            ]
674
                        ]);
112 efrain 675
 
676
 
677
                        //print_r($push);
678
 
1 www 679
                        $pushMapper->insert($push);
680
                    }
681
                }
682
 
112 efrain 683
                if(!$is_foreground) {
684
                    $dataSync = $this->getSyncData($user,false, false);
685
                }
686
            }
1 www 687
 
688
 
689
            //error_log('$max_date_changes_db = ' . $max_date_changes_db);
690
 
691
            $dt = \DateTime::createFromFormat('Y-m-d H:i:s', $max_date_changes_db);
692
            if($dt) {
693
                $max_date_changes_db = $dt->format($serviceDatetimeFormat);
694
            } else {
695
                $max_date_changes_db = '';
696
            }
697
 
698
            $data = [
699
                'success'   => true,
700
                'data'      =>[
701
                    'user' => [
702
                        'uuid' => $user->uuid,
703
                        'first_name' => $user->first_name,
704
                        'last_name' => $user->last_name,
705
                        'email' => $user->email,
706
                        'image' => $this->url()->fromRoute('services/storage',['type' => 'user', 'code' => $user->uuid, 'filename' => $user->image], ['force_canonical' => true]),
707
                    ],
112 efrain 708
                    'new_capsules' => $newCapsules,
1 www 709
                    'max_date_changes' => $max_date_changes_db,
710
                    'topics'    => isset( $dataSync['topics'] ) ? $dataSync['topics'] : [],
711
                    'quizzes'   => isset( $dataSync['quizzes'] ) ? $dataSync['quizzes'] : [],
52 efrain 712
                    'extended'=> isset( $dataSync['extended'] ) ? $dataSync['extended'] : [],
1 www 713
                ]
714
            ];
715
 
716
            //error_log(print_r($data, true));
717
 
718
            return new JsonModel($data);
719
        }
720
 
721
        return new JsonModel([
722
            'success' => false,
723
            'data' => 'ERROR_METHOD_NOT_ALLOWED'
724
        ]);
725
 
726
    }
727
 
728
 
729
 
730
    public function microlearningRefreshAction()
731
    {
732
        $request = $this->getRequest();
733
 
734
        if($request->isGet()) {
735
            $currentUserPlugin = $this->plugin('currentUserPlugin');
736
            $user = $currentUserPlugin->getUser();
737
 
738
            $dataSync = $this->getSyncData($user,false, false);
739
 
740
            //Cargamos la fecha máxima del cambio
741
            $companyMicrolearningUserMapper = CompanyMicrolearningUserMapper::getInstance($this->adapter);
742
            $max_date_changes_db = $companyMicrolearningUserMapper->fetchMaxDateChanges($user->id);
743
 
744
            //Si la fecha es vacia agregamos la fecha máxima de la asignación de la capsula
745
            if(!$max_date_changes_db) {
746
                $companyUsers = [];
747
                $companyMicrolearningCapsuleUserMapper = CompanyMicrolearningCapsuleUserMapper::getInstance($this->adapter);
748
                $capsules = $companyMicrolearningCapsuleUserMapper->fetchAllActiveByUserId($user->id);
749
                foreach($capsules as $capsule)
750
                {
751
 
752
 
753
 
754
                    if(empty($companyUsers[$capsule->company_id])) {
755
                        $companyUsers[$capsule->company_id] = $capsule->updated_on;
756
                    } else {
757
 
758
                        if($capsule->updated_on > $companyUsers[$capsule->company_id]) {
759
                            $companyUsers[$capsule->company_id] = $capsule->updated_on;
760
                        }
761
 
762
                    }
763
 
764
                }
765
 
766
                $max_date_changes_db = '';
767
                foreach($companyUsers as $company_id => $update_on)
768
                {
769
 
770
                    $max_date_changes_db = $max_date_changes_db < $update_on ? $update_on : $max_date_changes_db;
771
 
772
                    $companyMicrolearningUser = new CompanyMicrolearningUser();
773
                    $companyMicrolearningUser->company_id = $company_id;
774
                    $companyMicrolearningUser->user_id = $user->id;
775
                    $companyMicrolearningUser->added_on = $update_on;
776
                    $companyMicrolearningUser->updated_on = $update_on;
777
 
778
                    $companyMicrolearningUserMapper->insert($companyMicrolearningUser);
779
                }
780
            }
781
 
782
            $dt = \DateTime::createFromFormat('Y-m-d H:i:s', $max_date_changes_db);
783
            if($dt) {
784
                $serviceDatetimeFormat = $this->config['leaderslinked.services.datetime'];
785
                $max_date_changes_db = $dt->format($serviceDatetimeFormat);
786
            } else {
787
                $max_date_changes_db = '';
788
            }
789
 
790
            return new JsonModel([
791
                'success'   => true,
792
                'data'      =>[
793
                    'user' => [
794
                        'uuid' => $user->uuid,
795
                        'first_name' => $user->first_name,
796
                        'last_name' => $user->last_name,
797
                        'email' => $user->email,
798
                        'image' => $this->url()->fromRoute('services/storage',['type' => 'user', 'code' => $user->uuid, 'filename' => $user->image], ['force_canonical' => true]),
799
                    ],
800
                    'max_date_changes' => $max_date_changes_db,
801
                    'topics'    => $dataSync['topics'],
802
                    'quizzes'   => $dataSync['quizzes'],
52 efrain 803
                    'extended'   => $dataSync['extended'],
1 www 804
 
805
                ]
806
            ]);
807
        }
808
 
809
        return new JsonModel([
810
            'success' => false,
811
            'data' => 'ERROR_METHOD_NOT_ALLOWED'
812
        ]);
813
    }
814
 
815
 
816
    public function signinAction()
817
    {
818
        $request = $this->getRequest();
819
 
820
        if($request->isPost()) {
821
 
113 efrain 822
            /*
112 efrain 823
            $rawdata = file_get_contents("php://input");
824
            error_log('url = ' . $_SERVER['REQUEST_URI']);
825
            error_log('query = ' . $_SERVER['QUERY_STRING']);
826
            error_log('$rawdata = ' . $rawdata );
113 efrain 827
            */
1 www 828
 
829
            $application_id = filter_var($this->params()->fromPost('application_id', 0), FILTER_SANITIZE_NUMBER_INT);
830
            $device_uuid    = filter_var($this->params()->fromPost('device_uuid', ''), FILTER_SANITIZE_STRING);
831
            $email          = filter_var($this->params()->fromPost('email', ''), FILTER_SANITIZE_EMAIL);
832
            $password       = filter_var($this->params()->fromPost('password', ''), FILTER_SANITIZE_STRING);
219 efrain 833
            $encrypter      = filter_var($this->params()->fromPost('encrypter', ''), FILTER_SANITIZE_STRING);
1 www 834
 
835
 
836
 
837
            $ok = $application_id && $device_uuid && strlen($device_uuid) == 36;
838
            $ok = $ok && $email && $password;
839
            //$ok = $ok && in_array($encrypter, ['CryptoJsAes','RNCryptor','AesCipher']);
840
 
841
            if(!$ok) {
842
                return new JsonModel([
843
                    'success' => false,
844
                    'data' => 'ERROR_PARAMETERS_ARE_INVALID',
845
                ]);
846
            }
847
 
848
 
849
            $applicationMapper = ApplicationMapper::getInstance($this->adapter);
850
            $application = $applicationMapper->fetchOne($application_id);
851
            if(!$application) {
852
                return new JsonModel([
853
                    'success' => false,
854
                    'data' => 'ERROR_APPLICATION_NOT_FOUND',
855
                ]);
856
            }
857
 
858
            if($application->status == Application::STATUS_INACTIVE) {
859
                return new JsonModel([
860
                    'success' => false,
861
                    'data' => 'ERROR_APPLICATION_IS_INACTIVE',
862
                ]);
863
            }
864
 
865
 
866
            $deviceMapper = DeviceMapper::getInstance($this->adapter);
867
            $device = $deviceMapper->fetchOne($device_uuid);
868
            if(!$device) {
869
                $device                 = new Device();
870
                $device->id             = $device_uuid;
871
                $device->application_id = $application->id;
872
                $device->ip             = Functions::getUserIP();
873
                $device->aes            = Functions::generatePassword(16);
874
                $device->password       = Functions::generatePassword(32);
875
                $result                 = $deviceMapper->insert($device);
876
 
877
                if(!$result) {
878
                    return new JsonModel([
879
                        'success' => false,
880
                        'data' => 'ERROR_DEVICE_NOT_FOUND',
881
                    ]);
882
                }
883
            }
884
 
41 efrain 885
 
886
 
219 efrain 887
 
1 www 888
            if($encrypter == 'CryptoJsAes') {
889
 
890
 
891
                $email = html_entity_decode($email);
892
                $password = html_entity_decode($password);
893
 
894
 
895
                ob_start();
896
 
897
                $email      = CryptoJsAes::decrypt($email, $device->aes);
898
                $password   = CryptoJsAes::decrypt($password, $device->aes);
899
 
900
                ob_end_clean();
901
 
902
                if(!$email || !$password) {
903
                    return new JsonModel([
904
                        'success' => false,
905
                        'data' => 'ERROR_WEBSERVICE_PASSWORD_ENCRYPTION_FAILED',
906
                    ]);
907
                }
908
            } else if($encrypter == 'RNCryptor') {
909
                $cryptor = new \RNCryptor\RNCryptor\Decryptor;
910
                $email = $cryptor->decrypt($email, $device->aes);
911
                $password = $cryptor->decrypt($password, $device->aes);
912
 
913
                if(!$email || !$password) {
914
                    return new JsonModel([
915
                        'success' => false,
916
                        'data' => 'ERROR_WEBSERVICE_PASSWORD_ENCRYPTION_FAILED',
917
                    ]);
918
                }
919
 
920
 
921
            } else if($encrypter == 'AesCipher') {
922
 
923
                $emailDecrypted = AesCipher::decrypt($device->aes,$email);
924
                $passwordDecrypted = AesCipher::decrypt($device->aes,$password);
925
                if($emailDecrypted->hasError() || $passwordDecrypted->hasError()) {
926
                    return new JsonModel([
927
                        'success' => false,
928
                        'data' => 'ERROR_WEBSERVICE_PASSWORD_ENCRYPTION_FAILED',
929
                    ]);
930
                }
931
 
932
                $email = $emailDecrypted->getData();
933
                $password = $passwordDecrypted->getData();
219 efrain 934
            }
1 www 935
 
936
 
937
            $authAdapter = new AuthAdapter($this->adapter);
938
            $authAdapter->setData($email, $password);
939
 
940
            $authService = new AuthenticationService();
941
            $result = $authService->authenticate($authAdapter);
942
 
943
            if($result->getCode() == AuthResult::SUCCESS) {
944
 
945
                $userMapper = UserMapper::getInstance($this->adapter);
946
                $user = $userMapper->fetchOneByEmail($email);
947
 
948
 
949
                $device->user_id    = $user->id;
950
                $device->ip         = Functions::getUserIP();
951
                if($deviceMapper->update($device)) {
952
 
953
                    $ip = Functions::getUserIP();
954
 
955
                    $deviceHistoryMapper = DeviceHistoryMapper::getInstance($this->adapter);
956
                    $deviceHistory = $deviceHistoryMapper->fetchOneByDeviceIdAndUserIdAndIp($device->id, $user->id, $ip);
957
                    if($deviceHistory) {
958
                        $deviceHistoryMapper->update($deviceHistory);
959
                    } else {
960
                        $deviceHistory = new DeviceHistory();
961
                        $deviceHistory->device_id = $device->id;
962
                        $deviceHistory->user_id = $user->id;
963
                        $deviceHistory->ip = $ip;
964
                        $deviceHistoryMapper->insert($deviceHistory);
965
                    }
966
 
967
                    $pushMapper = PushMapper::getInstance($this->adapter);
968
 
969
                    $userDevices =  $deviceMapper->fetchAllByUserId($user->id);
970
                    foreach($userDevices as $userDevice)
971
                    {
972
 
973
 
974
                        if($userDevice->id != $device->id && $userDevice->token) {
975
 
976
                            $push = new Push();
977
                            $push->status = Push::STATUS_PENDING;
978
                            $push->data = json_encode([
979
                                'server' => [
980
                                    'key' =>   $application->key
981
                                 ],
982
                                 'push' => [
983
                                    'registration_ids'   => [
984
                                        $userDevice->token,
985
                                     ],
986
                                     /*'notification' => [
987
                                         'body' =>  'Se registro un inicio de sessión desde otro dispositivo',
988
                                         'title' => 'Inicio de sessión',
989
                                         'vibrate' => 1,
990
                                         'sound' =>  1
991
                                     ],*/
992
                                    'data' => [
993
                                        'command' => 'signout'
994
                                    ]
995
                                 ]
996
                             ]);
997
 
998
                            $pushMapper->insert($push);
999
 
1000
                        }
1001
                    }
1002
 
1003
 
1004
                    $companyUsers = [];
1005
                    $companyMicrolearningCapsuleUserMapper = CompanyMicrolearningCapsuleUserMapper::getInstance($this->adapter);
1006
                    $capsules = $companyMicrolearningCapsuleUserMapper->fetchAllActiveByUserId($user->id);
1007
                    foreach($capsules as $capsule)
1008
                    {
1009
 
1010
 
1011
 
1012
                        if(empty($companyUsers[$capsule->company_id])) {
1013
                            $companyUsers[$capsule->company_id] = $capsule->updated_on;
1014
                        } else {
1015
 
1016
                            if($capsule->updated_on > $companyUsers[$capsule->company_id]) {
1017
                                $companyUsers[$capsule->company_id] = $capsule->updated_on;
1018
                            }
1019
 
1020
                        }
1021
 
1022
                    }
1023
 
1024
                    $companyMicrolearningUserMapper = CompanyMicrolearningUserMapper::getInstance($this->adapter);
1025
 
1026
                    $maxDateChanges = $companyMicrolearningUserMapper->fetchMaxDateChanges($user->id);
1027
                    if(!$maxDateChanges) {
1028
 
1029
 
1030
                        $maxDateChanges = '';
1031
                        foreach($companyUsers as $company_id => $update_on)
1032
                        {
1033
 
1034
                            $maxDateChanges = $maxDateChanges < $update_on ? $update_on : $maxDateChanges;
1035
 
1036
                            $companyMicrolearningUser = new CompanyMicrolearningUser();
1037
                            $companyMicrolearningUser->company_id = $company_id;
1038
                            $companyMicrolearningUser->user_id = $user->id;
1039
                            $companyMicrolearningUser->added_on = $update_on;
1040
                            $companyMicrolearningUser->updated_on = $update_on;
1041
 
1042
                            $companyMicrolearningUserMapper->insert($companyMicrolearningUser);
1043
                        }
1044
 
1045
 
1046
                    }
1047
 
1048
 
1049
 
1050
                   $dt = \DateTime::createFromFormat('Y-m-d H:i:s', $maxDateChanges);
1051
                   if($dt) {
1052
                       $serviceDatetimeFormat = $this->config['leaderslinked.services.datetime'];
1053
                       $maxDateChanges = $dt->format($serviceDatetimeFormat);
1054
                   } else {
1055
                       $maxDateChanges = '';
1056
                   }
1057
 
1058
 
1059
                    $data = [
1060
                        'success'   => true,
1061
                        'data'      =>[
1062
                            'user' => [
1063
                                'uuid' => $user->uuid,
1064
                                'first_name' => $user->first_name,
1065
                                'last_name' => $user->last_name,
1066
                                'email' => $user->email,
1067
                                'image' => $this->url()->fromRoute('services/storage',['type' => 'user', 'code' => $user->uuid, 'filename' => $user->image], ['force_canonical' => true]),
1068
 
1069
                             ],
1070
                            'max_date_changes' => $maxDateChanges,
1071
                            'device' => [
1072
                                'aes' => $device->aes,
1073
                                'password' => $device->password
1074
                            ]
1075
 
1076
                        ]
1077
                    ];
1078
 
1079
                    if($application->id == Application::TWOGETSKILLS) {
1080
                        $dataSync = $this->getSyncData($user);
1081
 
1082
                        $data['data']['topics'] = $dataSync['topics'];
1083
                        $data['data']['quizzes'] = $dataSync['quizzes'];
1084
                        $data['data']['userlog'] = $dataSync['userlog'];
1085
                        $data['data']['progress'] = $dataSync['progress'];
52 efrain 1086
                        $data['data']['extended'] = $dataSync['extended'];
1 www 1087
                    }
1088
 
1089
 
1090
 
1091
                    return new JsonModel($data);
1092
 
1093
 
1094
 
1095
                } else {
1096
                    return new JsonModel([
1097
                        'success' => false,
1098
                        'data' => 'ERROR_THERE_WAS_AN_ERROR',
1099
                    ]);
1100
                }
1101
 
1102
 
1103
            } else {
1104
                $message = $result->getMessages()[0];
1105
                if(!in_array($message, ['ERROR_USER_NOT_FOUND', 'ERROR_USER_PROVIDER_NOT_FOUND', 'ERROR_USER_EMAIL_HASNT_BEEN_VARIFIED', 'ERROR_USER_IS_BLOCKED',
1106
                    'ERROR_USER_IS_INACTIVE', 'ERROR_ENTERED_PASS_INCORRECT_USER_IS_BLOCKED', 'ERROR_ENTERED_PASS_INCORRECT_2',
1107
                    'ERROR_ENTERED_PASS_INCORRECT_1'])) {
1108
                }
1109
 
1110
                switch($message)
1111
                {
1112
                    case 'ERROR_USER_NOT_FOUND' :
1113
                        $this->logger->err('Error de ingreso a LeadersLinked de ' . $email . ' - Email no existe', ['ip' => Functions::getUserIP()]);
1114
                        break;
1115
 
1116
                    case 'ERROR_USER_EMAIL_HASNT_BEEN_VARIFIED' :
1117
                        $this->logger->err('Error de ingreso a LeadersLinked de ' . $email . ' - Email no verificado', ['ip' => Functions::getUserIP()]);
1118
                        break;
1119
 
1120
                    case 'ERROR_USER_IS_BLOCKED' :
1121
                        $this->logger->err('Error de ingreso a LeadersLinked de ' . $email . ' - Usuario bloqueado', ['ip' => Functions::getUserIP()]);
1122
                        break;
1123
 
1124
                    case 'ERROR_USER_IS_INACTIVE' :
1125
                        $this->logger->err('Error de ingreso a LeadersLinked de ' . $email . ' - Usuario inactivo', ['ip' => Functions::getUserIP()]);
1126
                        break;
1127
 
1128
 
1129
                    case 'ERROR_ENTERED_PASS_INCORRECT_USER_IS_BLOCKED':
1130
                        $this->logger->err('Error de ingreso a LeadersLinked de ' . $email . ' - 3er Intento Usuario bloqueado', ['ip' => Functions::getUserIP()]);
1131
                        break;
1132
 
1133
 
1134
                    case 'ERROR_ENTERED_PASS_INCORRECT_2' :
1135
                        $this->logger->err('Error de ingreso a LeadersLinked de ' . $email . ' - 1er Intento', ['ip' => Functions::getUserIP()]);
1136
                        break;
1137
 
1138
 
1139
                    case 'ERROR_ENTERED_PASS_INCORRECT_1' :
1140
                        $this->logger->err('Error de ingreso a LeadersLinked de ' . $email . ' - 2do Intento', ['ip' => Functions::getUserIP()]);
1141
                        break;
1142
 
1143
 
1144
                    default :
1145
                        $message = 'ERROR_UNKNOWN';
1146
                        $this->logger->err('Error de ingreso a LeadersLinked de ' . $email . ' - Error desconocido', ['ip' => Functions::getUserIP()]);
1147
                        break;
1148
 
1149
 
1150
                }
1151
 
1152
 
1153
                return new JsonModel([
1154
                    'success'   => false,
1155
                    'data'   => $message
1156
                ]);
1157
            }
1158
 
1159
        }
1160
 
1161
        return new JsonModel([
1162
            'success' => false,
1163
            'data' => 'ERROR_METHOD_NOT_ALLOWED'
1164
        ]);
1165
 
1166
    }
1167
 
1168
 
1169
 
1170
 
1171
    public function storageAction()
1172
    {
1173
 
1174
        // Get the file name from GET variable.
1175
        $code       = $this->params()->fromRoute('code', '');
1176
        $fileName   = $this->params()->fromRoute('filename', '');
1177
        $type       = $this->params()->fromRoute('type', 'user');
1178
 
1179
 
1180
        $no_image = $this->config['leaderslinked.images_default.no_image'];
1181
        $path = '';
1182
        switch($type)
1183
        {
1184
            case 'user' :
1185
                $no_image = $this->config['leaderslinked.images_default.user_image'];
1186
                $path = $this->config['leaderslinked.fullpath.user'];
1187
                break;
1188
 
1189
 
1190
            case 'user-profile' :
1191
                $no_image = $this->config['leaderslinked.images_default.user_profile'];
1192
                $path = $this->config['leaderslinked.fullpath.user'];
1193
                break;
1194
 
1195
            case 'user-cover' :
1196
                $no_image = $this->config['leaderslinked.images_default.user_cover'];
1197
                $path = $this->config['leaderslinked.fullpath.user'];
1198
                break;
1199
 
1200
            case 'company' :
1201
                $no_image = $this->config['leaderslinked.images_default.company_profile'];
1202
                $path = $this->config['leaderslinked.fullpath.company'];
1203
                break;
1204
 
1205
            case 'company-cover' :
1206
                $no_image = $this->config['leaderslinked.images_default.company_cover'];
1207
                $path = $this->config['leaderslinked.fullpath.company'];
1208
                break;
1209
 
1210
            case 'group' :
1211
                $no_image = $this->config['leaderslinked.images_default.group_profile'];
1212
                $path = $this->config['leaderslinked.fullpath.group'];
1213
                break;
1214
 
1215
            case 'group-cover' :
1216
                $no_image = $this->config['leaderslinked.images_default.group_cover'];
1217
                $path = $this->config['leaderslinked.fullpath.group'];
1218
                break;
1219
 
1220
            case 'job' :
1221
                $path = $this->config['leaderslinked.fullpath.job'];
1222
                break;
1223
 
1224
            case 'chat' :
1225
                $path = $this->config['leaderslinked.fullpath.chat'];
1226
                break;
1227
 
1228
            case 'feed' :
1229
                $path = $this->config['leaderslinked.fullpath.feed'];
1230
                break;
1231
 
1232
            case 'post' :
1233
                $path = $this->config['leaderslinked.fullpath.post'];
1234
                break;
1235
 
1236
            case 'microlearning-topic' :
1237
                $path = $this->config['leaderslinked.fullpath.microlearning_topic'];
1238
                break;
1239
 
1240
            case 'microlearning-capsule' :
1241
                $path = $this->config['leaderslinked.fullpath.microlearning_capsule'];
1242
                break;
1243
 
1244
            case 'microlearning-slide' :
1245
                $path = $this->config['leaderslinked.fullpath.microlearning_slide'];
1246
                break;
1247
 
1248
            default :
1249
                $path = $this->config['leaderslinked.fullpath.image'];
1250
                break;
1251
 
1252
        }
1253
        if($code && $fileName) {
1254
            $request_fullpath = $path . $code . DIRECTORY_SEPARATOR . $fileName;
1255
        } else {
1256
            $request_fullpath = $no_image;
1257
        }
1258
 
1259
        if(empty($fileName)) {
1260
            $extensions     = explode('.',$request_fullpath);
1261
            $extension      = strtolower(trim($extensions[count($extensions)-1]));
1262
            if ($extension=='jpg' || $extension=='jpeg' || $extension=='gif' || $extension == 'png') {
1263
                $request_fullpath =  $no_image;
1264
            }
1265
        }
1266
 
1267
 
1268
        if(file_exists($request_fullpath)) {
1269
 
1270
            // Try to open file
1271
            if (!is_readable($request_fullpath)) {
1272
                return $this->getResponse()->setStatusCode(500);
1273
            }
1274
 
1275
            // Get file size in bytes.
1276
            $fileSize = filesize($request_fullpath);
1277
 
1278
            // Get MIME type of the file.
1279
            $mimeType = mime_content_type($request_fullpath);
1280
            if($mimeType===false) {
1281
                $mimeType = 'application/octet-stream';
1282
            }
1283
 
1284
            $request_fullpath = trim($request_fullpath);
1285
            $length = strlen($request_fullpath);
1286
            if(substr($request_fullpath, $length - 1) == '/') {
1287
                $request_fullpath = substr($request_fullpath, 0, $length - 1);
1288
            }
1289
 
1290
 
1291
            $filename = basename($request_fullpath);
1292
 
1293
            header('Content-type: ' . $mimeType);
1294
            readfile($request_fullpath);
1295
 
1296
 
1297
            exit;
1298
            //header("X-Sendfile: $request_fullpath");
1299
            //header("Content-type: application/octet-stream");
1300
            //header('Content-Disposition: attachment; filename="' . basename($filename) . '"');
1301
 
1302
 
1303
            /*
1304
 
1305
 
1306
            if ($fd = fopen ($request_fullpath, "r")) {
1307
 
1308
                $fsize = filesize($request_fullpath);
1309
 
1310
                header("Content-type: $mimeType");
1311
                header("Accept-Ranges: bytes");
1312
 
1313
                //header("Content-Disposition: attachment; filename=\"$filename\"");
1314
 
1315
                header("Content-length: $fsize");
1316
                header("Cache-control: private");
1317
 
1318
                while(!feof($fd)) {
1319
                    $buffer = fread($fd, 2048);
1320
                    echo $buffer;
1321
                }
1322
            }
1323
 
1324
            fclose ($fd);
1325
            exit;*/
1326
 
1327
 
1328
            /*
1329
             $fileContent = file_get_contents($request_fullpath);
1330
            $response = $this->getResponse();
1331
            $headers = $response->getHeaders();
1332
            $headers->addHeaderLine('Accept-Ranges: bytes');
1333
            $headers->addHeaderLine('Content-type: ' . $mimeType);
1334
            $headers->addHeaderLine('Content-length: ' . $fileSize);
1335
 
1336
            /*
1337
            Date: Tue, 13 Jul 2021 03:11:42 GMT
1338
            Server: Apache/2.4.41 (Ubuntu)
1339
            Last-Modified: Mon, 28 Jun 2021 16:43:04 GMT
1340
            ETag: "54e4-5c5d62eed581e"
1341
            Accept-Ranges: bytes
1342
            Content-Length: 21732
1343
            Cache-Control: max-age=1
1344
            Expires: Tue, 13 Jul 2021 03:11:43 GMT
1345
            Keep-Alive: timeout=5, max=100
1346
            Connection: Keep-Alive
1347
            Content-Type: audio/mpeg
1348
            */
1349
 
1350
            /*
1351
            if($fileContent!==false) {
1352
                error_log($_SERVER['REQUEST_URI']);
1353
                error_log($request_fullpath);
1354
                return $response->setContent($fileContent);
1355
 
1356
                header('Content-Type: '.$mimeType );
1357
                readfile_chunked($filename);
1358
                exit;
1359
 
1360
            } else {
1361
                error_log('500');
1362
                $this->getResponse()->setStatusCode(500);
1363
                return;
1364
            }*/
1365
        } else {
1366
            error_log('404');
1367
            return $this->getResponse()->setStatusCode(404);
1368
        }
1369
 
1370
        return $this->getResponse();
1371
    }
1372
 
1373
 
1374
    public function syncAction()
1375
    {
1376
        $request = $this->getRequest();
1377
 
1378
        if($request->isPost()) {
1379
 
221 efrain 1380
 
1 www 1381
 
1382
 
1383
            $serviceDatetimeFormat = $this->config['leaderslinked.services.datetime'];
1384
 
1385
            $device_uuid    = filter_var($this->params()->fromPost('device_uuid', ''), FILTER_SANITIZE_STRING);
1386
            $sync_id        = filter_var($this->params()->fromPost('sync_id', ''), FILTER_SANITIZE_NUMBER_INT);
1387
            $data           = $this->params()->fromPost('data', '');
1388
 
1389
 
1390
 
41 efrain 1391
            //error_log('device_uuid = ' . $device_uuid);
1392
            //error_log('sync_id = ' . $sync_id);
1393
            //error_log(print_r($data, true));
221 efrain 1394
 
1395
 
1396
            $rawdata = file_get_contents("php://input");
1397
            error_log('$rawdata = ' . $rawdata );
1 www 1398
 
1399
            $ok = $device_uuid && strlen($device_uuid) == 36 && $data && $sync_id;
1400
 
1401
            if(!$ok) {
1402
                return new JsonModel([
1403
                    'success' => false,
1404
                    'data' => 'ERROR_PARAMETERS_ARE_INVALID',
1405
                ]);
1406
            }
1407
 
1408
            $deviceMapper = DeviceMapper::getInstance($this->adapter);
1409
            $device = $deviceMapper->fetchOne($device_uuid);
1410
 
1411
 
1412
            if(!$device) {
1413
                return new JsonModel([
1414
                    'success' => false,
1415
                    'data' => 'ERROR_DEVICE_NOT_FOUND'
1416
                ]);
1417
            } else {
1418
                $device->ip = Functions::getUserIP();
1419
                $deviceMapper->update($device);
1420
            }
1421
 
44 efrain 1422
 
41 efrain 1423
 
44 efrain 1424
 
1425
 
1426
            $data = json_decode($data, true);
1427
            $sync_type      = isset($data['sync_type']) ? filter_var($data['sync_type'], FILTER_SANITIZE_STRING) : '';
1428
            $user_uuid      = isset($data['user_uuid']) ? filter_var($data['user_uuid'], FILTER_SANITIZE_STRING) : '';
1429
            $company_uuid   = isset($data['company_uuid']) ? filter_var($data['company_uuid'], FILTER_SANITIZE_STRING) :  '';
1430
 
1431
 
41 efrain 1432
            $syncLog = new SyncLog();
1433
            $syncLog->data = $data;
44 efrain 1434
            $syncLog->type = $sync_type;
41 efrain 1435
            $syncLog->device_uuid = $device->id;
1436
            $syncLog->ip = Functions::getUserIP();
1437
 
222 efrain 1438
 
223 efrain 1439
           print_r($data); exit;
222 efrain 1440
 
41 efrain 1441
            $syncLogMapper = SyncLogMapper::getInstance($this->adapter);
1442
            $syncLogMapper->insert($syncLog);
1443
 
1 www 1444
 
1445
    //
1446
 
1447
            if($user_uuid && $device->application_id = Application::TWOGETSKILLS  && $company_uuid && in_array($sync_type, ['microlearning-progress', 'microlearning-userlog', 'microlearning-quiz'])) {
1448
                $userMapper = UserMapper::getInstance($this->adapter);
1449
                $user = $userMapper->fetchOneByUuid($user_uuid);
1450
 
1451
                if(!$user) {
1452
                    return new JsonModel([
1453
                        'success' => false,
1454
                        'data' => [
1455
                            'sync_id' => $sync_id,
1456
                            'message' => 'ERROR_USER_NOT_FOUND',
1457
                            'fatal' => true
1458
                        ]
1459
                    ]);
1460
                }
1461
 
1462
 
1463
                if($user->status != User::STATUS_ACTIVE) {
1464
                    return new JsonModel([
1465
                        'success' => false,
1466
                        'data' => [
1467
                            'sync_id' => $sync_id,
1468
                            'message' => 'ERROR_USER_IS_NOT_ACTIVE',
1469
                            'fatal' => true
1470
                        ]
1471
                    ]);
1472
                }
1473
 
1474
                $companyMapper = CompanyMapper::getInstance($this->adapter);
1475
                $company = $companyMapper->fetchOneByUuid($company_uuid);
1476
                if(!$company) {
1477
                    return new JsonModel([
1478
                        'success' => false,
1479
                        'data' => [
1480
                            'sync_id' => $sync_id,
1481
                            'message' => 'ERROR_COMPANY_NOT_FOUND',
1482
                            'fatal' => true
1483
                        ]
1484
                    ]);
1485
                }
1486
 
1487
                if($company->status != Company::STATUS_ACTIVE) {
1488
                    return new JsonModel([
1489
                        'success' => false,
1490
                        'data' => [
1491
                            'sync_id' => $sync_id,
1492
                            'message' => 'ERROR_COMPANY_IS_NOT_FOUND',
1493
                            'fatal' => true
1494
                        ]
1495
                    ]);
1496
                }
1497
 
1498
 
1499
 
1500
 
1501
 
1502
                $companyServiceMapper = CompanyServiceMapper::getInstance($this->adapter);
1503
                $companyService = $companyServiceMapper->fetchOneByCompanyIdAndServiceId($company->id, Service::MICRO_LEARNING);
1504
                if(!$companyService) {
1505
                    return new JsonModel([
1506
                        'success' => false,
1507
                        'data' => [
1508
                            'sync_id' => $sync_id,
1509
                            'message' => 'ERROR_COMPANY_SERVICE_NOT_FOUND',
1510
                            'fatal' => true
1511
                        ]
1512
                    ]);
1513
                }
1514
 
1515
                $serviceActive = true;
1516
                $now = date('Y-m-d H:i:s');
1517
                if($companyService->status == CompanyService::ACTIVE) {
1518
 
1519
                    if($now < $companyService->paid_from || $now > $companyService->paid_to) {
1520
                        $serviceActive = false;
1521
                    }
1522
 
1523
                } else {
1524
                    $serviceActive = false;
1525
                }
1526
 
1527
                if( !$serviceActive) {
1528
                    return new JsonModel([
1529
                        'success' => false,
1530
                        'data' => [
1531
                            'sync_id' => $sync_id,
1532
                            'message' => 'ERROR_COMPANY_SERVICE_IS_NOT_ACTIVE',
1533
                            'fatal' => true
1534
                        ]
1535
                    ]);
1536
                }
1537
 
1538
                $topicMapper = CompanyMicrolearningTopicMapper::getInstance($this->adapter);
1539
                $topic_uuid = isset($data['topic_uuid']) ? filter_var($data['topic_uuid'], FILTER_SANITIZE_STRING) :  '';
1540
                if($topic_uuid) {
1541
                    $topic = $topicMapper->fetchOneByUuid($topic_uuid);
1542
 
1543
                    if(!$topic) {
1544
                        return new JsonModel([
1545
                            'success' => false,
1546
                            'data' => [
1547
                                'sync_id' => $sync_id,
1548
                                'message' => 'ERROR_TOPIC_NOT_FOUND',
1549
                            ]
1550
                        ]);
1551
                    }
1552
 
1553
                    if($topic->company_id != $company->id) {
1554
                        return new JsonModel([
1555
                            'success' => false,
1556
                            'data' => [
1557
                                'sync_id' => $sync_id,
1558
                                'message' => 'ERROR_INVALID_PARAMETERS_TOPIC_COMPANY',
1559
                            ]
1560
                        ]);
1561
                    }
1562
 
1563
                } else {
1564
                    $topic = null;
1565
                }
1566
 
1567
                $capsule_uuid     = isset($data['capsule_uuid']) ? filter_var($data['capsule_uuid'], FILTER_SANITIZE_STRING) :  '';
1568
                $capsuleMapper = CompanyMicrolearningCapsuleMapper::getInstance($this->adapter);
1569
                if($capsule_uuid) {
1570
 
1571
                    $capsule = $capsuleMapper->fetchOneByUuid($capsule_uuid);
1572
                    if(!$capsule) {
1573
                        return new JsonModel([
1574
                            'success' => false,
1575
                            'data' => [
1576
                                'sync_id' => $sync_id,
1577
                                'message' => 'ERROR_CAPSULE_NOT_FOUND',
1578
                            ]
1579
                        ]);
1580
                    }
1581
 
1582
                    if(!$topic || $capsule->topic_id != $topic->id) {
1583
                        return new JsonModel([
1584
                            'success' => false,
1585
                            'data' => [
1586
                                'sync_id' => $sync_id,
1587
                                'message' => 'ERROR_INVALID_PARAMETERS_CAPSULE_TOPIC',
1588
                            ]
1589
                        ]);
1590
                    }
1591
                } else {
1592
                    $capsule = null;
1593
                }
1594
 
1595
                if($capsule) {
1596
 
1597
                    $capsuleActive = true;
1598
                    $capsuleMapper = CompanyMicrolearningCapsuleUserMapper::getInstance($this->adapter);
1599
                    $capsuleUser = $capsuleMapper->fetchOneByUserIdAndCapsuleId($user->id, $capsule->id);
1600
 
1601
 
1602
                    $now = date('Y-m-d H:i:s');
1603
                    if($capsuleUser && in_array($capsuleUser->access, [CompanyMicrolearningCapsuleUser::ACCESS_UNLIMITED,CompanyMicrolearningCapsuleUser::ACCESS_PAY_PERIOD ])) {
1604
 
1605
 
1606
                        if($capsuleUser->access == CompanyMicrolearningCapsuleUser::ACCESS_PAY_PERIOD) {
1607
 
1608
                            if($now < $capsuleUser->paid_from || $now > $capsuleUser->paid_to) {
1609
                                $capsuleActive = false;;
1610
                            }
1611
                        }
1612
 
1613
                    } else {
1614
                        $capsuleActive = false;
1615
                    }
1616
 
1617
                    if(!$capsuleActive) {
1618
                        return new JsonModel([
1619
                            'success' => false,
1620
                            'data' => [
1621
                                'sync_id' => $sync_id,
1622
                                'message' => 'ERROR_YOU_DO_NOT_HAVE_ACCESS_TO_THIS_CAPSULE',
1623
                            ]
1624
                        ]);
1625
                    }
1626
                }
1627
 
1628
                $slideMapper = CompanyMicrolearningSlideMapper::getInstance($this->adapter);
1629
                $slide_uuid      = isset($data['slide_uuid']) ? filter_var($data['slide_uuid'], FILTER_SANITIZE_STRING) :  '';
1630
                if($slide_uuid) {
1631
                    $slide = $slideMapper->fetchOneByUuid($slide_uuid);
1632
                    if(!$slide) {
1633
                        return new JsonModel([
1634
                            'success' => false,
1635
                            'data' => [
1636
                                'sync_id' => $sync_id,
1637
                                'message' => 'ERROR_SLIDE_NOT_FOUND',
1638
                            ]
1639
                        ]);
1640
                    }
1641
 
1642
                    if(!$capsule || $slide->capsule_id != $capsule->id) {
1643
                        return new JsonModel([
1644
                            'success' => false,
1645
                            'data' => [
1646
                                'sync_id' => $sync_id,
1647
                                'message' => 'ERROR_INVALID_PARAMETERS_SLIDE_CAPSULE',
1648
                            ]
1649
                        ]);
1650
                    }
1651
                } else {
1652
                    $slide = null;
1653
                }
1654
 
1655
                if($sync_type == 'microlearning-quiz') {
1656
                    $ok = true;
1657
 
1658
                    $quiz_uuid = isset($data['quiz_uuid']) ? $data['quiz_uuid'] : '';
1659
                    $quizMapper = CompanyMicrolearningQuizMapper::getInstance($this->adapter);
1660
 
1661
                    $quiz = $quizMapper->fetchOneByUuid($quiz_uuid);
1662
                    if(!$quiz) {
1663
                        return new JsonModel([
1664
                            'success' => false,
1665
                            'data' => [
1666
                                'sync_id' => $sync_id,
1667
                                'message' => 'ERROR_SLIDE_NOT_FOUND',
1668
                            ]
1669
                        ]);
1670
                    }
1671
 
1672
                    if(!$capsule || $slide->capsule_id != $capsule->id) {
1673
                        return new JsonModel([
1674
                            'success' => false,
1675
                            'data' => [
1676
                                'sync_id' => $sync_id,
1677
                                'message' => 'ERROR_INVALID_PARAMETERS_QUIZ_SLIDE',
1678
                            ]
1679
                        ]);
1680
                    }
1681
 
1682
                    $added_on   = isset($data['added_on'])      ? filter_var($data['added_on'], FILTER_SANITIZE_STRING)  :  '';
1683
 
1684
                    $dt = \DateTime::createFromFormat($serviceDatetimeFormat, $added_on);
1685
                    if(!$dt) {
1686
                        $ok = false;
1687
                    } else {
1688
                        $added_on = $dt->format('Y-m-d H:i:s');
1689
                    }
1690
 
1691
 
1692
                    if(isset($data['points'])) {
1693
                        $points = intval($data['points'], 10);
1694
                    } else {
1695
                        $ok = false;
1696
                    }
1697
 
1698
 
1699
                    if(isset($data['pass'])) {
1700
                        $status = $data['pass'] == 'yes' ? CompanyMicrolearningUserQuiz::STATUS_PASS : CompanyMicrolearningUserQuiz::STATUS_FAIL;
1701
                    } else {
1702
                        $ok = false;
1703
                    }
1704
 
1705
 
1706
                    if(!$ok) {
1707
                        return new JsonModel([
1708
                            'success' => false,
1709
                            'data' => [
1710
                                'sync_id' => $sync_id,
1711
                                'message' => 'ERROR_INVALID_PARAMETERS',
1712
                            ]
1713
                        ]);
1714
                    }
1715
 
1716
 
1717
                    $array_response = [];
1718
                    $response = isset($data['response']) ? intval($data['response'], 10) : 0;
1719
                    for($i = 0; $i < $response; $i++)
1720
                    {
1721
                        $question_uuid = isset($data["response_{$i}_question_uuid"]) ? $data["response_{$i}_question_uuid"] : '';
1722
                        $answer_uuid = isset($data["response_{$i}_answer_uuid"]) ? $data["response_{$i}_answer_uuid"] : '';
1723
                        $value = isset($data["response_{$i}_value"]) ?  intval($data["response_{$i}_value"], 10) : 0;
1724
                        $points = isset($data["response_{$i}_points"]) ?  intval($data["response_{$i}_points"], 10) : 0;
1725
 
1726
                        if($question_uuid && $answer_uuid)
1727
                        {
1728
                            array_push($array_response, [
1729
                                'question_uuid' => $question_uuid,
1730
                                'answer_uuid' => $answer_uuid,
1731
                                'value' => $value,
1732
                                'points' => $points
1733
 
1734
                            ]);
1735
                        }
1736
 
1737
 
1738
                    }
1739
 
1740
 
1741
                    $userQuiz = new CompanyMicrolearningUserQuiz();
1742
                    $userQuiz->company_id = $company->id;
1743
                    $userQuiz->topic_id = $topic->id;
1744
                    $userQuiz->capsule_id = $capsule->id;
1745
                    $userQuiz->slide_id = $slide->id;
1746
                    $userQuiz->quiz_id = $quiz->id;
1747
                    $userQuiz->user_id = $user->id;
1748
                    $userQuiz->added_on = $added_on;
1749
                    $userQuiz->points = $points;
1750
                    $userQuiz->status = $status;
1751
                    $userQuiz->response = json_encode($array_response);
1752
 
1753
                    $userQuizMapper = CompanyMicrolearningUserQuizMapper::getInstance($this->adapter);
1754
 
1755
                    if($userQuizMapper->insert($userQuiz)) {
1756
                        return new JsonModel([
1757
                            'success' => true,
1758
                            'data' => [
1759
                                'sync_id' => $sync_id
1760
                            ]
1761
                        ]);
1762
                    } else {
1763
                        return new JsonModel([
1764
                            'success' => false,
1765
                            'data' => [
1766
                                'sync_id' => $sync_id,
1767
                                'message' => $userQuizMapper->getError()
1768
                            ]
1769
                        ]);
1770
                    }
1771
 
1772
                }
1773
 
1774
 
1775
                if($sync_type == 'microlearning-progress') {
1776
                    $ok = true;
1777
 
1778
                    $type = isset($data['type']) ? $data['type'] : '';
1779
                    switch($type)
1780
                    {
1781
                        case CompanyMicrolearningUserProgress::TYPE_TOPIC :
1782
                            if(!$topic) {
1783
                                $ok = false;
1784
                            }
1785
                            break;
1786
 
1787
                        case CompanyMicrolearningUserProgress::TYPE_CAPSULE :
1788
                            if(!$topic || !$capsule) {
1789
                                $ok = false;
1790
                            }
1791
                            break;
1792
 
1793
                        case CompanyMicrolearningUserProgress::TYPE_SLIDE :
1794
                            if(!$topic || !$capsule || !$slide) {
1795
                                $ok = false;
1796
                            }
1797
                            break;
1798
 
1799
                        default :
1800
                            $ok = false;
1801
                            break;
1802
 
1803
                    }
1804
 
1805
 
1806
                    $added_on   = isset($data['added_on'])      ? filter_var($data['added_on'], FILTER_SANITIZE_STRING)  :  '';
1807
                    $updated_on = isset($data['updated_on'])    ? filter_var($data['updated_on'], FILTER_SANITIZE_STRING) :  '';
1808
 
1809
                    $dt = \DateTime::createFromFormat($serviceDatetimeFormat, $added_on);
1810
                    if(!$dt) {
1811
                        $ok = false;
1812
                    } else {
1813
                        $added_on = $dt->format('Y-m-d H:i:s');
1814
                    }
1815
 
1816
                    $dt = \DateTime::createFromFormat($serviceDatetimeFormat, $updated_on );
1817
                    if(!$dt) {
1818
                        $ok = false;
1819
                    } else {
1820
                        $updated_on = $dt->format('Y-m-d H:i:s');
1821
                    }
1822
 
1823
                    if(!$ok) {
1824
                        return new JsonModel([
1825
                            'success' => false,
1826
                            'data' => [
1827
                                'sync_id' => $sync_id,
1828
                                'message' => 'ERROR_INVALID_PARAMETERS',
1829
                            ]
1830
                        ]);
1831
                    }
1832
 
1833
                           //$progress                   = isset($data['progress'])                  ? floatval($data['progress']) :  0;
1834
                    //$total_slides               = isset($data['total_slides'])              ? intval($data['total_slides'], 10) :  0;
1835
                    //$view_slides                = isset($data['view_slides'])               ? intval($data['view_slides'], 10) :  0;
1836
                    $returning                  = isset($data['returning'])                 ? intval($data['returning'], 10) :  0;
1837
                    $returning_after_completed  = isset($data['returning_after_completed']) ? intval($data['returning_after_completed'], 10) :  0;
1838
                    $completed                  = isset($data['completed'])                 ? intval($data['completed'], 10) :  0;
1839
 
1840
                    $progressMapper = CompanyMicrolearningUserProgressMapper::getInstance($this->adapter);
1841
                    $recordProgress = null;
1842
                    switch($type) {
1843
                        case CompanyMicrolearningUserProgress::TYPE_TOPIC  :
1844
                            $recordProgress = $progressMapper->fetchOneByUserIdAndTopicId($user->id, $topic->id);
1845
 
1846
                            break;
1847
 
1848
                        case CompanyMicrolearningUserProgress::TYPE_CAPSULE  :
1849
                            $recordProgress = $progressMapper->fetchOneByUseridAndCapsuleId($user->id, $capsule->id);
1850
                            break;
1851
 
1852
                        case CompanyMicrolearningUserProgress::TYPE_SLIDE  :
1853
                            $recordProgress = $progressMapper->fetchOneByUserIdAndSlideId($user->id, $slide->id);
1854
                            break;
1855
 
1856
                        default :
1857
                            $recordProgress= null;
1858
                    }
1859
 
1860
 
1861
                    if(!$recordProgress) {
1862
                        $recordProgress = new CompanyMicrolearningUserProgress();
1863
 
1864
                        $recordProgress->user_id    = $user->id;
1865
                        $recordProgress->type       = $type;
1866
                        $recordProgress->company_id = $topic->company_id;
1867
                        $recordProgress->topic_id   = $topic->id;
1868
                        $recordProgress->capsule_id = $capsule ? $capsule->id : null;
1869
                        $recordProgress->slide_id   = $slide ? $slide->id : null;
1870
                        $recordProgress->added_on   = $added_on;
1871
                    }
1872
                    $recordProgress->returning                  = $returning;
1873
                    $recordProgress->returning_after_completed  = $returning_after_completed;
1874
                    $recordProgress->completed                  = $completed;
1875
 
1876
                    if($type == CompanyMicrolearningUserProgress::TYPE_TOPIC ) {
1877
 
1878
                        $capsule_ids = [];
1879
                        $companyMicrolearningCapsuleUser = CompanyMicrolearningCapsuleUserMapper::getInstance($this->adapter);
1880
                        $records =  $companyMicrolearningCapsuleUser->fetchAllActiveByUserId($user->id);
1881
                        foreach($records as $record)
1882
                        {
1883
                            if($now >= $record->paid_from || $now <= $capsuleUser->paid_to) {
1884
                                if(!in_array($record->capsule_id, $capsule_ids)) {
1885
                                    array_push($capsule_ids, $record->capsule_id);
1886
                                }
1887
                            }
1888
                        }
1889
 
1890
                        $view_slides    = 0;
1891
                        $total_slides   = 0;
1892
                        foreach($capsule_ids as $capsule_id)
1893
                        {
1894
                            $view_slides    += $progressMapper->fetchCountAllSlideViewedByUserIdAndCapsuleId($user->id, $capsule_id);
1895
                            $total_slides   += $slideMapper->fetchTotalCountByCompanyIdAndTopicIdAndCapsuleId($topic->company_id, $topic->id, $capsule_id);
1896
 
1897
                        }
1898
 
1899
 
1900
                        $recordProgress->progress       = $total_slides > 0 ? (($view_slides * 100) / $total_slides) : 0;
1901
                        $recordProgress->total_slides   = $total_slides;
1902
                        $recordProgress->view_slides    = $view_slides;
1903
                    }
1904
                    else if($type == CompanyMicrolearningUserProgress::TYPE_CAPSULE ) {
1905
                        $view_slides    = $progressMapper->fetchCountAllSlideViewedByUserIdAndCapsuleId($user->id, $capsule->id);
1906
                        $total_slides   = $slideMapper->fetchTotalCountByCompanyIdAndTopicIdAndCapsuleId($topic->company_id, $capsule->topic_id, $capsule->id);
1907
 
1908
                        $recordProgress->progress       = $total_slides > 0 ? (($view_slides * 100) / $total_slides) : 0;
1909
                        $recordProgress->total_slides   = $total_slides;
1910
                        $recordProgress->view_slides    = $view_slides;
1911
                    }
1912
                    else {
1913
                        $recordProgress->progress       = 0;
1914
                        $recordProgress->total_slides   = 0;
1915
                        $recordProgress->view_slides    = 0;
1916
                    }
1917
 
1918
                    $recordProgress->updated_on = $updated_on;
1919
 
1920
 
1921
 
1922
                    if($recordProgress->id) {
1923
                        $result = $progressMapper->update($recordProgress);
1924
                    } else {
1925
                        $result = $progressMapper->insert($recordProgress);
1926
                    }
1927
 
1928
                    if($result) {
1929
                        return new JsonModel([
1930
                            'success' => true,
1931
                            'data' => [
1932
                                'sync_id' => $sync_id
1933
                            ]
1934
                        ]);
1935
                    } else {
1936
                        return new JsonModel([
1937
                            'success' => false,
1938
                            'data' => [
1939
                                'sync_id' => $sync_id,
1940
                                'message' => $progressMapper->getError()
1941
                            ]
1942
                        ]);
1943
                    }
1944
                }
1945
 
1946
 
1947
 
1948
                if($sync_type == 'microlearning-userlog') {
1949
                    $activity   = isset($data['activity'])      ? filter_var($data['activity'], FILTER_SANITIZE_STRING)  :  '';
1950
                    $added_on   = isset($data['added_on'])      ? filter_var($data['added_on'], FILTER_SANITIZE_STRING)  :  '';
1951
 
1952
 
1953
                    if(empty($activity)) {
1954
                        $ok = false;
1955
                    }
1956
 
1957
                    $dt = \DateTime::createFromFormat($serviceDatetimeFormat, $added_on);
1958
                    if(!$dt) {
1959
                        $ok = false;
1960
                    } else {
1961
                        $added_on = $dt->format('Y-m-d H:i:s');
1962
                    }
1963
 
1964
                    if(!$ok) {
1965
                        return new JsonModel([
1966
                            'success' => false,
1967
                            'data' => [
1968
                                'sync_id' => $sync_id,
1969
                                'message' => 'ERROR_INVALID_PARAMETERS',
1970
                            ]
1971
                        ]);
1972
                    }
1973
 
1974
                    $userLog = new CompanyMicrolearningUserLog();
1975
                    $userLog->activity      = $activity;
1976
                    $userLog->user_id       = $user->id;
1977
                    $userLog->company_id    = $topic->company_id;
1978
                    $userLog->topic_id      = $topic->id;
1979
                    $userLog->capsule_id    = $capsule ? $capsule->id : null;
1980
                    $userLog->slide_id      = $slide ? $slide->id : null;
1981
                    $userLog->added_on      = $added_on;
1982
 
1983
 
1984
 
1985
                    $userLogMapper = CompanyMicrolearningUserLogMapper::getInstance($this->adapter);
1986
                    if($userLogMapper->insert($userLog)) {
1987
                        return new JsonModel([
1988
                            'success' => true,
1989
                            'data' => [
1990
                                'sync_id' => $sync_id
1991
                            ]
1992
                        ]);
1993
                    } else {
1994
                        return new JsonModel([
1995
                            'success' => false,
1996
                            'data' => [
1997
                                'sync_id' => $sync_id,
1998
                                'message' => $userLogMapper->getError()
1999
                            ]
2000
                        ]);
2001
                    }
2002
                }
2003
 
2004
            }
2005
 
2006
 
2007
 
2008
 
2009
            if($user_uuid && $sync_type == 'userlog' && $device->application_id = Application::TWOGETSKILLS) {
2010
 
2011
                $userMapper = UserMapper::getInstance($this->adapter);
2012
                $user = $userMapper->fetchOneByUuid($user_uuid);
2013
 
2014
                if(!$user) {
2015
                    return new JsonModel([
2016
                        'success' => false,
2017
                        'data' => [
2018
                            'sync_id' => $sync_id,
2019
                            'message' => 'ERROR_USER_NOT_FOUND',
2020
                            'fatal' => true
2021
                        ]
2022
                    ]);
2023
                }
2024
 
2025
 
2026
                if($user->status != User::STATUS_ACTIVE) {
2027
                    return new JsonModel([
2028
                        'success' => false,
2029
                        'data' => [
2030
                            'sync_id' => $sync_id,
2031
                            'message' => 'ERROR_USER_IS_NOT_ACTIVE',
2032
                            'fatal' => true
2033
                        ]
2034
                    ]);
2035
                }
2036
 
2037
                $activity   = isset($data['activity'])      ? filter_var($data['activity'], FILTER_SANITIZE_STRING)  :  '';
2038
                $added_on   = isset($data['added_on'])      ? filter_var($data['added_on'], FILTER_SANITIZE_STRING)  :  '';
2039
 
2040
                if(empty($activity)) {
2041
                    $ok = false;
2042
                }
2043
 
2044
                $dt = \DateTime::createFromFormat($serviceDatetimeFormat, $added_on);
2045
                if(!$dt) {
2046
                    $ok = false;
2047
                } else {
2048
                    $added_on = $dt->format('Y-m-d H:i:s');
2049
                }
2050
 
2051
                if(!$ok) {
2052
                    return new JsonModel([
2053
                        'success' => false,
2054
                        'data' => [
2055
                            'sync_id' => $sync_id,
2056
                            'message' => 'ERROR_INVALID_PARAMETERS',
2057
                        ]
2058
                    ]);
2059
                }
2060
 
2061
                $userLog = new CompanyMicrolearningUserLog();
2062
                $userLog->company_id = null;
2063
                $userLog->user_id = $user->id;
2064
                $userLog->activity = $activity;
2065
                $userLog->added_on = $added_on;
2066
 
2067
 
2068
                $userLogMapper = CompanyMicrolearningUserLogMapper::getInstance($this->adapter);
2069
                if($userLogMapper->insert($userLog)) {
2070
                    return new JsonModel([
2071
                        'success' => true,
2072
                        'data' => [
2073
                            'sync_id' => $sync_id
2074
                        ]
2075
                    ]);
2076
                } else {
2077
                    return new JsonModel([
2078
                        'success' => false,
2079
                        'data' => [
2080
                            'sync_id' => $sync_id,
2081
                            'message' => $userLogMapper->getError()
2082
                        ]
2083
                    ]);
2084
                }
2085
            }
2086
 
2087
            return new JsonModel([
2088
                'success' => true,
2089
                'data' => [
2090
                    'sync_id' => $sync_id
2091
                ]
2092
            ]);
2093
 
2094
        }
2095
 
2096
        return new JsonModel([
2097
            'success' => false,
2098
            'data' => 'ERROR_METHOD_NOT_ALLOWED'
2099
        ]);
2100
    }
2101
 
2102
 
2103
    public function syncBatchAction()
2104
    {
2105
        $request = $this->getRequest();
2106
 
2107
        if($request->isPost()) {
2108
 
41 efrain 2109
 
1 www 2110
 
2111
            $serviceDatetimeFormat = $this->config['leaderslinked.services.datetime'];
2112
 
2113
            $device_uuid = filter_var($this->params()->fromPost('device_uuid', ''), FILTER_SANITIZE_STRING);
2114
            $max_records = filter_var($this->params()->fromPost('max_records', 0), FILTER_SANITIZE_NUMBER_INT);
41 efrain 2115
 
1 www 2116
            $ok = $device_uuid && strlen($device_uuid) == 36 && $max_records;
2117
 
2118
            if(!$ok) {
2119
                return new JsonModel([
2120
                    'success' => false,
2121
                    'data' => 'ERROR_PARAMETERS_ARE_INVALID',
2122
                ]);
2123
            }
2124
 
2125
            $deviceMapper = DeviceMapper::getInstance($this->adapter);
2126
            $device = $deviceMapper->fetchOne($device_uuid);
2127
 
2128
 
2129
            if(!$device) {
2130
                return new JsonModel([
2131
                    'success' => false,
2132
                    'data' => 'ERROR_DEVICE_NOT_FOUND'
2133
                ]);
2134
            } else {
2135
                $device->ip = Functions::getUserIP();
2136
                $deviceMapper->update($device);
2137
            }
41 efrain 2138
 
2139
 
1 www 2140
 
41 efrain 2141
 
2142
            $syncLogMapper = SyncLogMapper::getInstance($this->adapter);
2143
 
2144
 
2145
 
1 www 2146
            $result_sync_ids = [];
2147
 
2148
 
2149
 
2150
 
16 efrain 2151
            $users = [];
2152
            $companies = [];
2153
            $company_services = [];
2154
            $topics = [];
2155
            $capsules = [];
2156
            $capsule_users = [];
2157
            $slides = [];
2158
            $quizzes = [];
2159
            $questions = [];
2160
            $answers = [];
2161
 
2162
            $userMapper = UserMapper::getInstance($this->adapter);
2163
            $companyMapper = CompanyMapper::getInstance($this->adapter);
2164
            $companyServiceMapper = CompanyServiceMapper::getInstance($this->adapter);
2165
            $topicMapper = CompanyMicrolearningTopicMapper::getInstance($this->adapter);
2166
            $capsuleMapper = CompanyMicrolearningCapsuleMapper::getInstance($this->adapter);
2167
            $capsuleUserMapper = CompanyMicrolearningCapsuleUserMapper::getInstance($this->adapter);
2168
            $slideMapper = CompanyMicrolearningSlideMapper::getInstance($this->adapter);
2169
            $quizMapper = CompanyMicrolearningQuizMapper::getInstance($this->adapter);
2170
            $questionMapper = CompanyMicrolearningQuestionMapper::getInstance($this->adapter);
2171
            $answerMapper = CompanyMicrolearningAnswerMapper::getInstance($this->adapter);
2172
 
2173
 
2174
            $userProgressMapper = CompanyMicrolearningUserProgressMapper::getInstance($this->adapter);
2175
            $userLogMapper = CompanyMicrolearningUserLogMapper::getInstance($this->adapter);
2176
 
1 www 2177
            for($i = 1; $i <= $max_records; $i++)
2178
            {
2179
                $sync_id        = filter_var($this->params()->fromPost('record_sync_id' . $i, ''), FILTER_SANITIZE_NUMBER_INT);
2180
                $record_data    = $this->params()->fromPost('record_data' . $i, '');
2181
 
2182
                if(empty($record_data) || empty($sync_id )) {
2183
                    continue;
2184
                }
41 efrain 2185
 
1 www 2186
 
45 efrain 2187
 
1 www 2188
                $record         = json_decode($record_data, true);
2189
                $sync_type      = isset($record['sync_type']) ? filter_var($record['sync_type'],  FILTER_SANITIZE_STRING) : '';
2190
                $user_uuid      = isset($record['user_uuid']) ? filter_var($record['user_uuid'],  FILTER_SANITIZE_STRING) : '';
2191
                $company_uuid   = isset($record['company_uuid']) ? filter_var($record['company_uuid'], FILTER_SANITIZE_STRING) : '';
2192
 
2193
                if(!$sync_id) {
2194
                    continue;
2195
                }
2196
 
45 efrain 2197
                $syncLog = new SyncLog();
2198
                $syncLog->data = $record_data;
2199
                $syncLog->type = $sync_type;
2200
                $syncLog->device_uuid = $device->id;
2201
                $syncLog->ip = Functions::getUserIP();
2202
                $syncLogMapper->insert($syncLog);
2203
 
1 www 2204
                /***** INICIO MICROLEARNING *****/
2205
 
2206
                if($user_uuid && $device->application_id = Application::TWOGETSKILLS  && $company_uuid && in_array($sync_type, ['microlearning-progress', 'microlearning-userlog', 'microlearning-quiz'])) {
2207
 
16 efrain 2208
 
2209
                    if(isset($users[$user_uuid])) {
2210
                        $user = $users[$user_uuid];
2211
                    } else {
2212
 
2213
                        $user = $userMapper->fetchOneByUuid($user_uuid);
2214
                        if($user) {
2215
                            $users[$user_uuid] = $user;
2216
                        }
2217
                    }
2218
 
2219
 
1 www 2220
                    if(!$user) {
2221
                        array_push($result_sync_ids, [
2222
                            'success' => false,
2223
                            'sync_id' => $sync_id,
2224
                            'message' => 'ERROR_USER_NOT_FOUND',
2225
                            'fatal' => true
2226
                        ]);
2227
                        continue;
2228
                    }
2229
 
2230
 
2231
                    if($user->status != User::STATUS_ACTIVE) {
2232
                        array_push($result_sync_ids, [
2233
                            'success' => false,
2234
                            'sync_id' => $sync_id,
2235
                            'message' => 'ERROR_USER_IS_NOT_ACTIVE',
2236
                            'fatal' => true
2237
                        ]);
2238
                        continue;
2239
                    }
2240
 
16 efrain 2241
 
2242
                    if(isset($companies[$company_uuid])) {
2243
                        $company = $companies[$company_uuid];
2244
                    } else {
2245
                        $company = $companyMapper->fetchOneByUuid($company_uuid);
2246
                        if($company) {
2247
                            $companies[$company_uuid] = $company;
2248
                        }
2249
                    }
2250
 
2251
 
2252
 
2253
 
1 www 2254
                    if(!$company) {
2255
                        array_push($result_sync_ids, [
2256
                            'success' => false,
2257
                            'sync_id' => $sync_id,
2258
                            'message' => 'ERROR_COMPANY_NOT_FOUND',
2259
                            'fatal' => true
2260
                        ]);
2261
                        continue;
2262
                    }
2263
 
2264
                    if($company->status != Company::STATUS_ACTIVE) {
2265
                        array_push($result_sync_ids, [
2266
                            'success' => false,
2267
                            'sync_id' => $sync_id,
2268
                            'message' => 'ERROR_COMPANY_IS_NOT_FOUND',
2269
                            'fatal' => true
2270
                        ]);
2271
                        continue;
2272
                    }
2273
 
2274
 
2275
 
16 efrain 2276
                    $key = $company->id . '-' .  Service::MICRO_LEARNING;
2277
                    if(isset($company_services[$key])) {
2278
                        $companyService = $company_services[$key];
2279
                    } else {
2280
                        $companyService = $companyServiceMapper->fetchOneByCompanyIdAndServiceId($company->id, Service::MICRO_LEARNING);
2281
                        if($companyService) {
2282
                            $company_services[$key] = $companyService;
2283
                        }
2284
                    }
1 www 2285
 
2286
                    if(!$companyService) {
2287
                        array_push($result_sync_ids, [
2288
                            'success' => false,
2289
                            'sync_id' => $sync_id,
2290
                            'message' => 'ERROR_COMPANY_SERVICE_NOT_FOUND',
2291
                            'fatal' => true
2292
                        ]);
2293
                        continue;
2294
                    }
2295
 
2296
                    $serviceActive = true;
2297
                    $now = date('Y-m-d H:i:s');
2298
                    if($companyService->status == CompanyService::ACTIVE) {
2299
 
2300
                        if($now < $companyService->paid_from || $now > $companyService->paid_to) {
2301
                            $serviceActive = false;
2302
                        }
2303
 
2304
                    } else {
2305
                        $serviceActive = false;
2306
                    }
2307
 
2308
                    if( !$serviceActive) {
2309
                        array_push($result_sync_ids, [
2310
                            'success' => false,
2311
                            'sync_id' => $sync_id,
2312
                            'message' => 'ERROR_COMPANY_SERVICE_IS_NOT_ACTIVE',
2313
                            'fatal' => true
2314
                        ]);
2315
                        continue;
2316
                    }
2317
 
16 efrain 2318
 
1 www 2319
                    $topic_uuid = isset($record['topic_uuid']) ? filter_var($record['topic_uuid'], FILTER_SANITIZE_STRING) :  '';
2320
                    if($topic_uuid) {
2321
 
16 efrain 2322
                        if(isset($topics[$topic_uuid])) {
2323
                            $topic = $topics[$topic_uuid];
2324
                        } else {
2325
                            $topic = $topicMapper->fetchOneByUuid($topic_uuid);
2326
                            if($topic) {
2327
                                $topics[$topic_uuid] = $topic;
2328
                            }
2329
                        }
2330
 
1 www 2331
                        if(!$topic) {
2332
                            array_push($result_sync_ids, [
2333
                                'success' => false,
2334
                                'sync_id' => $sync_id,
2335
                                'message' => 'ERROR_TOPIC_NOT_FOUND',
2336
                            ]);
2337
                            continue;
2338
                        }
2339
 
2340
                        if($topic->company_id != $company->id) {
2341
                            array_push($result_sync_ids, [
2342
                                'success' => false,
2343
                                'sync_id' => $sync_id,
2344
                                'message' => 'ERROR_INVALID_PARAMETERS_TOPIC_COMPANY',
2345
                            ]);
2346
                            continue;
2347
                        }
2348
 
2349
                    } else {
2350
                        $topic = null;
2351
                    }
2352
 
2353
                    $capsule_uuid     = isset($record['capsule_uuid']) ? filter_var($record['capsule_uuid'], FILTER_SANITIZE_STRING) :  '';
16 efrain 2354
 
1 www 2355
                    if($capsule_uuid) {
2356
 
16 efrain 2357
                        if(isset($capsules[$capsule_uuid])) {
2358
                            $capsule = $capsules[$capsule_uuid];
2359
                        } else {
2360
                            $capsule = $capsuleMapper->fetchOneByUuid($capsule_uuid);
2361
                            if($capsule) {
2362
                                $capsules[$capsule_uuid] = $capsule;
2363
                            }
2364
                        }
1 www 2365
                        if(!$capsule) {
2366
                            array_push($result_sync_ids, [
2367
                                'success' => false,
2368
                                'sync_id' => $sync_id,
2369
                                'message' => 'ERROR_CAPSULE_NOT_FOUND',
2370
                            ]);
2371
                            continue;
2372
                        }
2373
 
2374
                        if(!$topic || $capsule->topic_id != $topic->id) {
2375
                            array_push($result_sync_ids, [
2376
                                'success' => false,
2377
                                'sync_id' => $sync_id,
2378
                                'message' => 'ERROR_INVALID_PARAMETERS_CAPSULE_TOPIC',
2379
                            ]);
2380
                            continue;
2381
                        }
2382
                    } else {
2383
                        $capsule = null;
2384
                    }
2385
 
2386
                    if($capsule) {
2387
 
2388
                        $capsuleActive = true;
2389
 
16 efrain 2390
                        $key = $user->id . '-' . $capsule->id;
1 www 2391
 
16 efrain 2392
                        if(isset($capsule_users[$key])) {
2393
                            $capsuleUser = $capsule_users[$key];
2394
                        } else {
2395
 
2396
                            $capsuleUser = $capsuleUserMapper->fetchOneByUserIdAndCapsuleId($user->id, $capsule->id);
2397
                            if($capsuleUser) {
2398
                                $capsule_users[$key] = $capsuleUser;
2399
                            }
2400
 
2401
                        }
2402
 
1 www 2403
                        $now = date('Y-m-d H:i:s');
2404
                        if($capsuleUser && in_array($capsuleUser->access, [CompanyMicrolearningCapsuleUser::ACCESS_UNLIMITED,CompanyMicrolearningCapsuleUser::ACCESS_PAY_PERIOD ])) {
2405
 
2406
 
2407
                            if($capsuleUser->access == CompanyMicrolearningCapsuleUser::ACCESS_PAY_PERIOD) {
2408
 
2409
                                if($now < $capsuleUser->paid_from || $now > $capsuleUser->paid_to) {
2410
                                    $capsuleActive = false;;
2411
                                }
2412
                            }
2413
 
2414
                        } else {
2415
                            $capsuleActive = false;
2416
                        }
2417
 
2418
                        if(!$capsuleActive) {
2419
                            array_push($result_sync_ids, [
2420
                                'success' => false,
2421
                                'sync_id' => $sync_id,
2422
                                'message' => 'ERROR_YOU_DO_NOT_HAVE_ACCESS_TO_THIS_CAPSULE',
2423
                            ]);
2424
                            continue;
2425
                        }
2426
                    }
2427
 
16 efrain 2428
 
1 www 2429
                    $slide_uuid      = isset($record['slide_uuid']) ? filter_var($record['slide_uuid'], FILTER_SANITIZE_STRING) :  '';
2430
                    if($slide_uuid) {
16 efrain 2431
 
2432
                        if(isset($slides[$slide_uuid])) {
2433
                            $slide = $slides[$slide_uuid];
2434
                        } else {
2435
 
2436
                            $slide = $slideMapper->fetchOneByUuid($slide_uuid);
2437
                            if($slide) {
2438
                                $slides[$slide_uuid] = $slide;
2439
                            }
2440
                        }
1 www 2441
                        if(!$slide) {
2442
                            array_push($result_sync_ids, [
2443
                                'success' => false,
2444
                                'sync_id' => $sync_id,
2445
                                'message' => 'ERROR_SLIDE_NOT_FOUND',
2446
                            ]);
2447
                            continue;
2448
                        }
2449
 
2450
                        if(!$capsule || $slide->capsule_id != $capsule->id) {
2451
                            array_push($result_sync_ids, [
2452
                                'success' => false,
2453
                                'sync_id' => $sync_id,
2454
                                'message' => 'ERROR_INVALID_PARAMETERS_SLIDE_CAPSULE',
2455
                            ]);
2456
                            continue;
2457
                        }
2458
                    } else {
2459
                        $slide = null;
2460
                    }
2461
 
2462
                    if($sync_type == 'microlearning-quiz') {
2463
                        $ok = true;
2464
 
2465
                        $quiz_uuid = isset($record['quiz_uuid']) ? $record['quiz_uuid'] : '';
16 efrain 2466
 
2467
                        if(isset($quizzes[$quiz_uuid])) {
2468
                            $quiz = $quizzes[$quiz_uuid];
2469
                        } else {
2470
                            $quiz = $quizMapper->fetchOneByUuid($quiz_uuid);
2471
                            if($quiz) {
2472
                                $quizzes[$quiz_uuid] = $quiz;
2473
                            }
2474
                        }
1 www 2475
                        if(!$quiz) {
2476
                            array_push($result_sync_ids, [
2477
                                'success' => false,
2478
                                'sync_id' => $sync_id,
2479
                                'message' => 'ERROR_SLIDE_NOT_FOUND',
2480
                            ]);
2481
                            continue;
2482
                        }
2483
 
2484
                        if(!$capsule || $slide->capsule_id != $capsule->id) {
2485
                            array_push($result_sync_ids, [
2486
                                'success' => false,
2487
                                'sync_id' => $sync_id,
2488
                                'message' => 'ERROR_INVALID_PARAMETERS_QUIZ_SLIDE',
2489
                            ]);
2490
                            continue;
2491
                        }
2492
 
2493
                        $added_on   = isset($record['added_on'])      ? filter_var($record['added_on'], FILTER_SANITIZE_STRING)  :  '';
2494
 
2495
                        $dt = \DateTime::createFromFormat($serviceDatetimeFormat, $added_on);
2496
                        if(!$dt) {
2497
                            $ok = false;
2498
                        } else {
2499
                            $added_on = $dt->format('Y-m-d H:i:s');
2500
                        }
2501
 
2502
                        if(isset($record['points'])) {
2503
                            $points = intval($record['points'], 10);
2504
                        } else {
2505
                            $ok = false;
2506
                        }
2507
 
2508
                        if(isset($record['pass'])) {
2509
                            $status = $record['pass'] == 'yes' ? CompanyMicrolearningUserQuiz::STATUS_PASS : CompanyMicrolearningUserQuiz::STATUS_FAIL;
2510
                        } else {
2511
                            $ok = false;
2512
                        }
2513
 
2514
                        if(!$ok) {
2515
                            array_push($result_sync_ids, [
2516
                                'success' => false,
2517
                                'sync_id' => $sync_id,
2518
                                'message' => 'ERROR_INVALID_PARAMETERS',
2519
                            ]);
2520
                            continue;
2521
                        }
2522
 
2523
                        $array_response = [];
2524
                        $response = isset($record['response']) ? intval($record['response'], 10) : 0;
2525
                        for($i = 0; $i < $response; $i++)
2526
                        {
2527
                            $question_uuid = isset($record["response_{$i}_question_uuid"]) ? $record["response_{$i}_question_uuid"] : '';
2528
                            $answer_uuid = isset($record["response_{$i}_answer_uuid"]) ? $record["response_{$i}_answer_uuid"] : '';
2529
                            $value = isset($record["response_{$i}_value"]) ?  intval($record["response_{$i}_value"], 10) : 0;
2530
                            $points = isset($record["response_{$i}_points"]) ?  intval($record["response_{$i}_points"], 10) : 0;
2531
 
16 efrain 2532
 
2533
                            if(isset($questions[$question_uuid])) {
2534
                                $question = $questions[$question_uuid];
2535
                            } else {
2536
                                $question = $questionMapper->fetchOneByUuid($question_uuid);
2537
                                if($question) {
2538
                                    $questions[$question_uuid] = $question;
2539
                                }
2540
                            }
2541
 
2542
                            if(!$question || $question->quiz_id != $quiz->id) {
2543
                                array_push($result_sync_ids, [
2544
                                    'success' => false,
2545
                                    'sync_id' => $sync_id,
2546
                                    'message' => 'ERROR_INVALID_PARAMETERS_QUIZ_QUESTION_SLIDE',
1 www 2547
                                ]);
16 efrain 2548
                                continue;
2549
                            }
2550
 
2551
                            if(isset($answers[$answer_uuid])) {
2552
                                $answer = $answers[$answer_uuid];
2553
                            } else {
2554
                                $answer = $answerMapper->fetchOneByUuid($answer_uuid);
2555
                                if($answer) {
2556
                                    $answers[$answer_uuid] = $answer;
2557
                                }
2558
                            }
2559
 
2560
                            if($answer && $answer->question_id != $question->id) {
2561
                                array_push($result_sync_ids, [
2562
                                    'success' => false,
2563
                                    'sync_id' => $sync_id,
2564
                                    'message' => 'ERROR_INVALID_PARAMETERS_QUIZ_ANSWER_SLIDE',
2565
                                ]);
2566
                                continue;
2567
                            }
2568
 
2569
                            array_push($array_response, [
2570
                                'question_uuid' => $question_uuid,
2571
                                'answer_uuid' => $answer_uuid,
2572
                                'value' => $value,
2573
                                'points' => $points
2574
                            ]);
1 www 2575
                        }
2576
 
2577
                        $userQuiz = new CompanyMicrolearningUserQuiz();
2578
                        $userQuiz->company_id = $company->id;
2579
                        $userQuiz->topic_id = $topic->id;
2580
                        $userQuiz->capsule_id = $capsule->id;
2581
                        $userQuiz->slide_id = $slide->id;
2582
                        $userQuiz->quiz_id = $quiz->id;
2583
                        $userQuiz->user_id = $user->id;
2584
                        $userQuiz->added_on = $added_on;
2585
                        $userQuiz->points = $points;
2586
                        $userQuiz->status = $status;
2587
                        $userQuiz->response = json_encode($array_response);
2588
 
2589
                        $userQuizMapper = CompanyMicrolearningUserQuizMapper::getInstance($this->adapter);
2590
 
2591
                        if($userQuizMapper->insert($userQuiz)) {
2592
                            array_push($result_sync_ids, [
2593
                                'success' => true,
2594
                                'sync_id' => $sync_id
2595
                            ]);
2596
                        } else {
2597
                            array_push($result_sync_ids, [
2598
                                'success' => false,
2599
                                'sync_id' => $sync_id,
2600
                                'message' => $userQuizMapper->getError()
2601
                            ]);
2602
                        }
2603
                        continue;
2604
                    }
2605
 
2606
                    if($sync_type == 'microlearning-progress') {
2607
                        $ok = true;
2608
 
2609
                        $type = isset($record['type']) ? $record['type'] : '';
2610
                        switch($type)
2611
                        {
2612
                            case CompanyMicrolearningUserProgress::TYPE_TOPIC :
2613
                                if(!$topic) {
2614
                                    $ok = false;
2615
                                }
2616
                                break;
2617
 
2618
                            case CompanyMicrolearningUserProgress::TYPE_CAPSULE :
2619
                                if(!$topic || !$capsule) {
2620
                                    $ok = false;
2621
                                }
2622
                                break;
2623
 
2624
                            case CompanyMicrolearningUserProgress::TYPE_SLIDE :
2625
                                if(!$topic || !$capsule || !$slide) {
2626
                                    $ok = false;
2627
                                }
2628
                                break;
2629
 
2630
                            default :
2631
                                $ok = false;
2632
                                break;
2633
                        }
2634
 
2635
                        $added_on   = isset($record['added_on'])      ? filter_var($record['added_on'], FILTER_SANITIZE_STRING)  :  '';
2636
                        $updated_on = isset($record['updated_on'])    ? filter_var($record['updated_on'], FILTER_SANITIZE_STRING) :  '';
2637
 
2638
                        $dt = \DateTime::createFromFormat($serviceDatetimeFormat, $added_on);
2639
                        if(!$dt) {
2640
                            $ok = false;
2641
                        } else {
2642
                            $added_on = $dt->format('Y-m-d H:i:s');
2643
                        }
2644
 
2645
                        $dt = \DateTime::createFromFormat($serviceDatetimeFormat, $updated_on );
2646
                        if(!$dt) {
2647
                            $ok = false;
2648
                        } else {
2649
                            $updated_on = $dt->format('Y-m-d H:i:s');
2650
                        }
2651
 
2652
                        if(!$ok) {
2653
                            array_push($result_sync_ids, [
2654
                                'success' => false,
2655
                                'sync_id' => $sync_id,
2656
                                'message' => 'ERROR_INVALID_PARAMETERS',
2657
                            ]);
2658
                            continue;
2659
                        }
2660
 
18 efrain 2661
                        $progress                   = isset($record['progress'])                  ? floatval($record['progress']) :  0;
2662
                        $total_slides               = isset($record['total_slides'])              ? intval($record['total_slides'], 10) :  0;
2663
                        $view_slides                = isset($record['view_slides'])               ? intval($record['view_slides'], 10) :  0;
1 www 2664
                        $returning                  = isset($record['returning'])                 ? intval($record['returning'], 10) :  0;
2665
                        $returning_after_completed  = isset($record['returning_after_completed']) ? intval($record['returning_after_completed'], 10) :  0;
2666
                        $completed                  = isset($record['completed'])                 ? intval($record['completed'], 10) :  0;
2667
 
16 efrain 2668
 
1 www 2669
                        $recordProgress = null;
2670
                        switch($type) {
2671
                            case CompanyMicrolearningUserProgress::TYPE_TOPIC  :
16 efrain 2672
                                $recordProgress = $userProgressMapper->fetchOneByUserIdAndTopicId($user->id, $topic->id);
1 www 2673
 
2674
                                break;
2675
 
2676
                            case CompanyMicrolearningUserProgress::TYPE_CAPSULE  :
16 efrain 2677
                                $recordProgress = $userProgressMapper->fetchOneByUseridAndCapsuleId($user->id, $capsule->id);
1 www 2678
                                break;
2679
 
2680
                            case CompanyMicrolearningUserProgress::TYPE_SLIDE  :
16 efrain 2681
                                $recordProgress = $userProgressMapper->fetchOneByUserIdAndSlideId($user->id, $slide->id);
1 www 2682
                                break;
2683
 
2684
                            default :
2685
                                $recordProgress= null;
2686
                        }
2687
 
2688
 
2689
                        if(!$recordProgress) {
2690
                            $recordProgress = new CompanyMicrolearningUserProgress();
2691
 
2692
                            $recordProgress->user_id    = $user->id;
2693
                            $recordProgress->type       = $type;
2694
                            $recordProgress->company_id = $topic->company_id;
2695
                            $recordProgress->topic_id   = $topic->id;
2696
                            $recordProgress->capsule_id = $capsule ? $capsule->id : null;
2697
                            $recordProgress->slide_id   = $slide ? $slide->id : null;
2698
                            $recordProgress->added_on   = $added_on;
43 efrain 2699
                        }
2700
                        /*
2701
                        else {
16 efrain 2702
 
2703
                            if($recordProgress->updated_on > $updated_on) {
2704
                                array_push($result_sync_ids, [
2705
                                    'success' => true,
2706
                                    'sync_id' => $sync_id,
2707
                                ]);
2708
                                continue;
2709
                            }
2710
 
2711
 
2712
 
43 efrain 2713
                        }*/
1 www 2714
                        $recordProgress->returning                  = $returning;
2715
                        $recordProgress->returning_after_completed  = $returning_after_completed;
2716
                        $recordProgress->completed                  = $completed;
2717
 
2718
                        if($type == CompanyMicrolearningUserProgress::TYPE_TOPIC ) {
2719
 
2720
                            $capsule_ids = [];
2721
                            $companyMicrolearningCapsuleUser = CompanyMicrolearningCapsuleUserMapper::getInstance($this->adapter);
2722
                            $records =  $companyMicrolearningCapsuleUser->fetchAllActiveByUserId($user->id);
2723
                            foreach($records as $record)
2724
                            {
2725
                                if($now >= $record->paid_from || $now <= $capsuleUser->paid_to) {
2726
                                    if(!in_array($record->capsule_id, $capsule_ids)) {
2727
                                        array_push($capsule_ids, $record->capsule_id);
2728
                                    }
2729
                                }
2730
                            }
18 efrain 2731
 
2732
                            $recordProgress->progress       = $progress;
1 www 2733
                            $recordProgress->total_slides   = $total_slides;
2734
                            $recordProgress->view_slides    = $view_slides;
2735
                        }
2736
                        else if($type == CompanyMicrolearningUserProgress::TYPE_CAPSULE ) {
18 efrain 2737
 
2738
                            $recordProgress->progress       = $progress;
1 www 2739
                            $recordProgress->total_slides   = $total_slides;
2740
                            $recordProgress->view_slides    = $view_slides;
2741
                        }
2742
                        else {
2743
                            $recordProgress->progress       = 0;
2744
                            $recordProgress->total_slides   = 0;
2745
                            $recordProgress->view_slides    = 0;
2746
                        }
2747
 
2748
                        $recordProgress->updated_on = $updated_on;
2749
 
2750
 
2751
 
2752
                        if($recordProgress->id) {
16 efrain 2753
                            $result = $userProgressMapper->update($recordProgress);
1 www 2754
                        } else {
16 efrain 2755
                            $result = $userProgressMapper->insert($recordProgress);
1 www 2756
                        }
2757
 
2758
                        if($result) {
2759
                            array_push($result_sync_ids, [
2760
                                'success' => true,
2761
                                'sync_id' => $sync_id
2762
                            ]);
2763
                        } else {
2764
                            array_push($result_sync_ids, [
2765
                                'success' => false,
2766
                                'sync_id' => $sync_id,
16 efrain 2767
                                'message' => $userProgressMapper->getError()
1 www 2768
                            ]);
2769
                        }
2770
                        continue;
2771
                    }
2772
 
2773
 
2774
 
2775
                    if($sync_type == 'microlearning-userlog') {
2776
                        $activity   = isset($record['activity'])      ? filter_var($record['activity'], FILTER_SANITIZE_STRING)  :  '';
2777
                        $added_on   = isset($record['added_on'])      ? filter_var($record['added_on'], FILTER_SANITIZE_STRING)  :  '';
2778
 
2779
 
2780
                        if(empty($activity)) {
2781
                            $ok = false;
2782
                        }
2783
 
2784
                        $dt = \DateTime::createFromFormat($serviceDatetimeFormat, $added_on);
2785
                        if(!$dt) {
2786
                            $ok = false;
2787
                        } else {
2788
                            $added_on = $dt->format('Y-m-d H:i:s');
2789
                        }
2790
 
2791
                        if(!$ok) {
2792
                            array_push($result_sync_ids, [
2793
                                'success' => false,
2794
                                'sync_id' => $sync_id,
2795
                                'message' => 'ERROR_INVALID_PARAMETERS',
2796
                            ]);
2797
                            continue;
2798
                        }
2799
 
2800
 
2801
 
2802
 
16 efrain 2803
                        $userLog = $userLogMapper->fetchLastBy($user->id);
2804
                        if($userLog) {
2805
                            $insert = $userLog->added_on <= $added_on;
2806
                        } else {
2807
                            $insert = true;
2808
                        }
2809
 
2810
 
2811
                        if($insert) {
2812
 
2813
                            $userLog = new CompanyMicrolearningUserLog();
2814
                            $userLog->activity      = $activity;
2815
                            $userLog->user_id       = $user->id;
2816
                            $userLog->company_id    = $topic->company_id;
2817
                            $userLog->topic_id      = $topic->id;
2818
                            $userLog->capsule_id    = $capsule ? $capsule->id : null;
2819
                            $userLog->slide_id      = $slide ? $slide->id : null;
2820
                            $userLog->added_on      = $added_on;
2821
 
2822
 
2823
 
2824
 
2825
                            if($userLogMapper->insert($userLog)) {
2826
                                array_push($result_sync_ids, [
2827
                                    'success' => true,
2828
                                    'sync_id' => $sync_id
2829
                                ]);
2830
                            } else {
2831
                                array_push($result_sync_ids, [
2832
                                    'success' => false,
2833
                                    'sync_id' => $sync_id,
2834
                                    'message' => $userLogMapper->getError()
2835
                                ]);
2836
                            }
2837
                        } else {
1 www 2838
                            array_push($result_sync_ids, [
2839
                                'success' => true,
16 efrain 2840
                                'sync_id' => $sync_id
1 www 2841
                            ]);
2842
                        }
2843
                        continue;
2844
                    }
2845
 
2846
                }
2847
 
2848
                /***** FIN MICROLEARNING *****/
2849
 
2850
 
2851
                /***** INICIO LOG DE USUARIO GENERAL *****/
2852
 
2853
                if($user_uuid && $sync_type == 'userlog' && $device->application_id = Application::TWOGETSKILLS) {
2854
 
2855
 
16 efrain 2856
                    if(isset($users[$user_uuid])) {
2857
                        $user = $users[$user_uuid];
2858
                    } else {
2859
                        $user = $userMapper->fetchOneByUuid($user_uuid);
2860
                        if($user) {
2861
                            $users[$user_uuid] = $user;
2862
                        }
2863
                    }
2864
 
2865
 
2866
 
2867
 
1 www 2868
                    if(!$user) {
2869
                        array_push($result_sync_ids, [
2870
                            'success' => false,
2871
                            'sync_id' => $sync_id,
2872
                            'message' => 'ERROR_USER_NOT_FOUND',
2873
                            'fatal' => true
2874
                        ]);
2875
                        continue;
2876
                    }
2877
 
2878
 
2879
                    if($user->status != User::STATUS_ACTIVE) {
2880
                        array_push($result_sync_ids, [
2881
                            'success' => false,
2882
                            'sync_id' => $sync_id,
2883
                            'message' => 'ERROR_USER_IS_NOT_ACTIVE',
2884
                            'fatal' => true
2885
                        ]);
2886
                        continue;
2887
                    }
2888
 
2889
                    $activity   = isset($record['activity'])      ? filter_var($record['activity'], FILTER_SANITIZE_STRING)  :  '';
2890
                    $added_on   = isset($record['added_on'])      ? filter_var($record['added_on'], FILTER_SANITIZE_STRING)  :  '';
2891
 
2892
                    if(empty($activity)) {
2893
                        $ok = false;
2894
                    }
2895
 
2896
                    $dt = \DateTime::createFromFormat($serviceDatetimeFormat, $added_on);
2897
                    if(!$dt) {
2898
                        $ok = false;
2899
                    } else {
2900
                        $added_on = $dt->format('Y-m-d H:i:s');
2901
                    }
2902
 
2903
                    if(!$ok) {
2904
                        array_push($result_sync_ids, [
2905
                            'success' => false,
2906
                            'sync_id' => $sync_id,
2907
                            'message' => 'ERROR_INVALID_PARAMETERS',
2908
                        ]);
2909
                        continue;
2910
                    }
2911
 
2912
 
16 efrain 2913
                    $userLog = $userLogMapper->fetchLastBy($user->id);
2914
                    if($userLog) {
2915
                        $insert = $userLog->added_on <= $added_on;
2916
                    } else {
2917
                        $insert = true;
2918
                    }
1 www 2919
 
16 efrain 2920
 
2921
                    if($insert) {
2922
                        $userLog = new CompanyMicrolearningUserLog();
2923
                        $userLog->company_id = null;
2924
                        $userLog->user_id = $user->id;
2925
                        $userLog->activity = $activity;
2926
                        $userLog->added_on = $added_on;
2927
 
2928
 
2929
                        $userLogMapper = CompanyMicrolearningUserLogMapper::getInstance($this->adapter);
2930
                        if($userLogMapper->insert($userLog)) {
2931
                            array_push($result_sync_ids, [
2932
                                'success' => true,
2933
                                'sync_id' => $sync_id
2934
                            ]);
2935
                        } else {
2936
                            array_push($result_sync_ids, [
2937
                                'success' => false,
2938
                                'sync_id' => $sync_id,
2939
                                'message' => $userLogMapper->getError()
2940
                            ]);
2941
                        }
2942
                    } else {
1 www 2943
                        array_push($result_sync_ids, [
2944
                            'success' => true,
2945
                            'sync_id' => $sync_id
2946
                        ]);
2947
                    }
2948
 
16 efrain 2949
 
2950
 
1 www 2951
                    continue;
2952
                }
2953
 
2954
                /***** FIN LOG DE USUARIO GENERAL ******/
2955
            }
2956
 
2957
            if( $result_sync_ids) {
2958
                return new JsonModel([
2959
                    'success' => true,
2960
                    'data' => $result_sync_ids
2961
                ]);
2962
            } else {
2963
                return new JsonModel([
2964
                    'success' => false,
2965
                    'data' => 'ERROR_INVALID_PARAMETERS'
2966
                ]);
2967
            }
2968
 
2969
 
2970
        }
2971
 
2972
        return new JsonModel([
2973
            'success' => false,
2974
            'data' => 'ERROR_METHOD_NOT_ALLOWED'
2975
        ]);
2976
    }
2977
 
2978
    /**
2979
     *
2980
     * @param User $user
2981
     * @param boolean $includeLogs
2982
     * @param boolean $includeProgress
2983
     * @return array[]
2984
     */
2985
    private function getSyncData($user, $includeLogs = true, $includeProgress = true)
2986
    {
2987
 
2988
        $serviceDatetimeFormat = $this->config['leaderslinked.services.datetime'];
2989
 
2990
        $data = [
2991
            'userlog'   => [],
2992
            'progress'  => [],
2993
            'topics'    => [],
2994
            'quizzes'   => [],
47 efrain 2995
            'extended'  => [],
1 www 2996
        ];
2997
 
2998
 
2999
        $companies = [];
3000
        $companyMapper = CompanyMapper::getInstance($this->adapter);
3001
 
3002
        $topics = [];
3003
        $topicMapper = CompanyMicrolearningTopicMapper::getInstance($this->adapter);
3004
 
3005
        $capsules = [];
3006
        $capsuleMapper = CompanyMicrolearningCapsuleMapper::getInstance($this->adapter);
3007
 
3008
        $slides = [];
3009
        $slideMapper = CompanyMicrolearningSlideMapper::getInstance($this->adapter);
3010
 
3011
        $quizzes = [];
3012
        $quizMapper = CompanyMicrolearningQuizMapper::getInstance($this->adapter);
3013
 
3014
        $questions = [];
3015
        $questionMapper = CompanyMicrolearningQuestionMapper::getInstance($this->adapter);
3016
 
3017
        $answers = [];
3018
        $answerMapper = CompanyMicrolearningAnswerMapper::getInstance($this->adapter);
3019
 
3020
 
3021
        $userLogMapper = CompanyMicrolearningUserLogMapper::getInstance($this->adapter);
3022
 
3023
        if($includeLogs) {
3024
 
54 efrain 3025
            //$records = $userLogMapper->fetchLast20ByUserId($user->id);
3026
            $records = $userLogMapper->fetchAllByUserId($user->id);
1 www 3027
            foreach($records as $record)
3028
            {
3029
                $dt = \DateTime::createFromFormat('Y-m-d H:i:s', $record->added_on);
3030
 
3031
                if($record->company_id) {
3032
 
3033
                    if(isset($companies[$record->company_id])) {
3034
                        $company = $companies[$record->company_id];
3035
                    } else {
3036
                        $company = $companyMapper->fetchOne($record->company_id);
3037
                        $companies[$record->company_id] = $company;
3038
                    }
3039
                } else {
3040
                    $company = null;
3041
                }
3042
 
3043
                if($record->topic_id) {
3044
 
3045
                    if(isset($topics[$record->topic_id])) {
3046
                        $topic = $topics[$record->topic_id];
3047
                    } else {
3048
                        $topic = $topicMapper->fetchOne($record->topic_id);
3049
                        $topics[$record->topic_id] = $topic;
3050
                    }
3051
                } else {
3052
                    $topic = null;
3053
                }
3054
 
3055
 
3056
                if($record->capsule_id) {
3057
 
3058
                    if(isset($capsules[$record->capsule_id])) {
3059
                        $capsule = $capsules[$record->capsule_id];
3060
                    } else {
3061
                        $capsule = $capsuleMapper->fetchOne($record->capsule_id);
3062
                        $capsules[$record->capsule_id] = $capsule;
3063
                    }
3064
                } else {
3065
                    $capsule = null;
3066
                }
3067
 
3068
 
3069
                if($record->slide_id) {
3070
 
3071
                    if(isset($slides[$record->slide_id])) {
3072
                        $slide = $slides[$record->slide_id];
3073
                    } else {
3074
                        $slide = $slideMapper->fetchOne($record->slide_id);
3075
                        $slides[$record->slide_id] = $slide;
3076
                    }
3077
                } else {
3078
                    $slide = null;
3079
                }
3080
 
3081
 
3082
                array_push($data['userlog'], [
3083
                    'user_uuid'     => $user->uuid,
3084
                    'company_uuid'  => $company ? $company->uuid : '',
3085
                    'topic_uuid'    => $topic ? $topic->uuid : '',
3086
                    'capsule_uuid'  => $capsule ? $capsule->uuid : '',
3087
                    'slide_uuid'    => $slide ? $slide->uuid : '',
3088
                    'activity'      => $record->activity,
3089
                    'added_on'      => $dt->format($serviceDatetimeFormat),
3090
                ]);
3091
 
3092
 
3093
            }
3094
        }
3095
 
3096
        if($includeProgress) {
3097
 
3098
            $userProgressMapper = CompanyMicrolearningUserProgressMapper::getInstance($this->adapter);
3099
            $records = $userProgressMapper->fetchAllByUserId($user->id);
3100
            foreach($records as $record)
3101
            {
3102
                if($record->company_id) {
3103
 
3104
                    if(isset($companies[$record->company_id])) {
3105
                        $company = $companies[$record->company_id];
3106
                    } else {
3107
                        $company = $companyMapper->fetchOne($record->company_id);
3108
                        $companies[$record->company_id] = $company;
3109
                    }
3110
                } else {
3111
                    $company = null;
3112
                }
3113
 
3114
                if($record->topic_id) {
3115
 
3116
                    if(isset($topics[$record->topic_id])) {
3117
                        $topic = $topics[$record->topic_id];
3118
                    } else {
3119
                        $topic = $topicMapper->fetchOne($record->topic_id);
3120
                        $topics[$record->topic_id] = $topic;
3121
                    }
3122
                } else {
3123
                    $topic = null;
3124
                }
3125
 
3126
 
3127
                if($record->capsule_id) {
3128
 
3129
                    if(isset($capsules[$record->capsule_id])) {
3130
                        $capsule = $capsules[$record->capsule_id];
3131
                    } else {
3132
                        $capsule = $capsuleMapper->fetchOne($record->capsule_id);
3133
                        $capsules[$record->capsule_id] = $capsule;
3134
                    }
3135
                } else {
3136
                    $capsule = null;
3137
                }
3138
 
3139
 
3140
                if($record->slide_id) {
3141
 
3142
                    if(isset($slides[$record->slide_id])) {
3143
                        $slide = $slides[$record->slide_id];
3144
                    } else {
3145
                        $slide = $slideMapper->fetchOne($record->slide_id);
3146
                        $slides[$record->slide_id] = $slide;
3147
                    }
3148
                } else {
3149
                    $slide = null;
3150
                }
3151
 
3152
 
3153
                $dtAddedOn = \DateTime::createFromFormat('Y-m-d H:i:s', $record->added_on);
3154
                $dtUpdatedOn = \DateTime::createFromFormat('Y-m-d H:i:s', $record->updated_on);
3155
 
3156
                array_push($data['progress'], [
3157
                    'user_uuid'                 => $user->uuid,
3158
                    'company_uuid'              => $company ? $company->uuid : '',
3159
                    'topic_uuid'                => $topic ? $topic->uuid : '',
3160
                    'capsule_uuid'              => $capsule ? $capsule->uuid : '',
3161
                    'slide_uuid'                => $slide ? $slide->uuid : '',
3162
                    'progress'                  => $record->progress ? $record->progress : 0,
3163
                    'total_slides'              => $record->total_slides ? $record->total_slides : 0,
3164
                    'view_slides'               => $record->view_slides ? $record->view_slides : 0,
3165
                    'type'                      => $record->type,
3166
                    'returning'                 => $record->returning ? $record->returning : 0,
3167
                    'returning_after_completed' => $record->returning_after_completed ? $record->returning_after_completed : 0,
3168
                    'completed'                 => $record->completed ? $record->completed : 0,
3169
                    'added_on'                  => $dtAddedOn->format($serviceDatetimeFormat),
3170
                    'updated_on'                => $dtUpdatedOn->format($serviceDatetimeFormat),
3171
                ]);
3172
            }
3173
        }
3174
 
3175
 
3176
        $now = date('Y-m-d H:i:s');
3177
        $companies_with_access  = [];
3178
        $topics_with_access     = [];
3179
        $capsules_with_access   = [];
3180
        $quizzes_with_access    = [];
3181
        $quizzes                = [];
3182
 
3183
 
3184
        $capsuleUserMapper = CompanyMicrolearningCapsuleUserMapper::getInstance($this->adapter);
3185
        $records = $capsuleUserMapper->fetchAllActiveByUserId($user->id);
3186
 
3187
 
3188
        foreach($records as $record)
3189
        {
3190
            if($record->access != CompanyMicrolearningCapsuleUser::ACCESS_UNLIMITED && $record->access != CompanyMicrolearningCapsuleUser::ACCESS_PAY_PERIOD) {
3191
                continue;
3192
            }
3193
            if($record->access == CompanyMicrolearningCapsuleUser::ACCESS_PAY_PERIOD) {
3194
                if($now < $record->paid_from || $now > $record->paid_to) {
3195
                    continue;
3196
                }
3197
            }
3198
 
3199
 
3200
            if(!in_array($record->company_id,$companies_with_access)) {
3201
                array_push($companies_with_access, $record->company_id);
3202
            }
3203
 
3204
            if(!in_array($record->topic_id,$topics_with_access)) {
3205
                array_push($topics_with_access, $record->topic_id);
3206
            }
3207
 
3208
            if(!in_array($record->capsule_id,$capsules_with_access)) {
3209
                array_push($capsules_with_access, $record->capsule_id);
3210
            }
3211
        }
3212
 
3213
 /*
3214
        echo '$companies_with_access ' . PHP_EOL;
3215
        print_r($companies_with_access);
3216
 
3217
        echo '$topics_with_access ' . PHP_EOL;
3218
        print_r($topics_with_access);
3219
 
3220
        echo '$capsules_with_access' . PHP_EOL;
3221
        print_r($capsules_with_access);
3222
        */
3223
 
3224
        $companyServiceMapper = CompanyServiceMapper::getInstance($this->adapter);
3225
        foreach($companies_with_access as $company_id)
3226
        {
3227
            $companyService =  $companyServiceMapper->fetchOneActiveByCompanyIdAndServiceId($company_id, Service::MICRO_LEARNING);
3228
 
3229
            //print_r($companyService); exit;
3230
 
3231
            if(!$companyService) {
3232
                continue;
3233
            }
3234
 
3235
 
3236
            if(isset($companies[$companyService->company_id])) {
3237
                $company = $companies[$companyService->company_id];
3238
            } else {
3239
                $company = $companyMapper->fetchOne($companyService->company_id);
3240
                $companies[$companyService->company_id] = $company;
3241
            }
3242
 
3243
            $topics = $topicMapper->fetchAllActiveByCompanyId($company_id);
3244
            foreach($topics as $topic)
3245
            {
3246
                if(!in_array($topic->id, $topics_with_access)) {
3247
                    continue;
3248
                }
3249
 
3250
                $record_capsules = [];
3251
                $capsules = $capsuleMapper->fetchAllActiveByCompanyIdAndTopicId($topic->company_id, $topic->id);
3252
                foreach($capsules as $capsule)
3253
                {
3254
                    if(!in_array($capsule->id, $capsules_with_access)) {
3255
                        continue;
3256
                    }
3257
 
3258
 
3259
                    $record_slides = [];
3260
                    $slides = $slideMapper->fetchAllByCompanyIdAndTopicIdAndCapsuleId($capsule->company_id, $capsule->topic_id, $capsule->id);
3261
                    foreach($slides as $slide)
3262
                    {
3263
                        if($slide->type == CompanyMicrolearningSlide::TYPE_QUIZ) {
3264
                            if(!in_array($slide->quiz_id, $quizzes_with_access)) {
3265
                                array_push($quizzes_with_access, $slide->quiz_id);
3266
                            }
3267
 
3268
                            if(isset($quizzes[$slide->quiz_id])) {
3269
                                $quiz = $quizzes[$slide->quiz_id];
3270
 
3271
                            } else {
3272
                                $quiz = $quizMapper->fetchOne($slide->quiz_id);
3273
                                $quizzes[$slide->quiz_id] =  $quiz;
3274
                            }
3275
                        } else {
3276
                            $quiz = null;
3277
                        }
3278
 
3279
 
3280
 
3281
                        array_push($record_slides, [
3282
                            'uuid' => $slide->uuid,
3283
                            'quiz_uuid' => $quiz ? $quiz->uuid : '',
3284
                            'name' => $slide->name ? $slide->name : '',
3285
                            'description' => $slide->description ? $slide->description : '',
3286
                            'position' => $slide->order,
3287
                            'type' => $slide->type,
3288
                            'background' => $slide->background ? $this->url()->fromRoute('services/storage',['type' => 'microlearning-slide', 'code' => $slide->uuid, 'filename' => $slide->background], ['force_canonical' => true]) : '',
3289
                            'file' => $slide->file ? $this->url()->fromRoute('services/storage',['type' => 'microlearning-slide', 'code' => $slide->uuid, 'filename' => $slide->file], ['force_canonical' => true]) : '',
3290
                        ]);
3291
                    }
3292
 
3293
                    array_push($record_capsules, [
3294
                        'uuid' => $capsule->uuid,
3295
                        'name' => $capsule->name ? $capsule->name : '',
3296
                        'description' => $capsule->description ? $capsule->description : '',
3297
                        'image' => $capsule->image ? $this->url()->fromRoute('services/storage',['type' => 'microlearning-capsule', 'code' => $capsule->uuid, 'filename' => $capsule->image ], ['force_canonical' => true])  : '',
3298
                        'position' => $capsule->order,
3299
                        'slides' => $record_slides,
3300
                    ]);
3301
                }
3302
 
3303
                array_push($data['topics'], [
3304
                    'uuid' => $topic->uuid,
3305
                    'name' => $topic->name ? $topic->name : '',
3306
                    'description' => $topic->description ? $topic->description : '',
3307
                    'image' => $topic->image ? $this->url()->fromRoute('services/storage',['type' => 'microlearning-topic', 'code' => $topic->uuid, 'filename' => $topic->image ], ['force_canonical' => true]) : '',
3308
                    'position' => $topic->order,
3309
                    'company_uuid' => $company->uuid,
3310
                    'company_name' => $company->name,
3311
                    'company_image' => $this->url()->fromRoute('services/storage',['type' => 'company', 'code' => $company->uuid, 'filename' => $company->image], ['force_canonical' => true]),
3312
                    'capsules' => $record_capsules
3313
                ]);
3314
            }
3315
        }
3316
 
3317
 
3318
 
3319
        foreach($quizzes_with_access as $quiz_id)
3320
        {
3321
            if(isset($quizzes[$quiz_id])) {
3322
                $quiz = $quizzes[$quiz_id];
3323
            } else {
3324
                $quiz = $quizMapper->fetchOne($quiz_id);
3325
                array_push($quizzes, $quiz);
3326
            }
3327
 
3328
            if(isset($companies[$quiz->company_id])) {
3329
                $company = $companies[$quiz->company_id];
3330
            } else {
3331
                $company = $companyMapper->fetchOne($quiz->company_id);
3332
                $companies[$quiz->company_id] = $company;
3333
            }
3334
 
3335
 
3336
            $record_questions = [];
3337
            $questions = $questionMapper->fetchAllByQuizId($quiz->id);
3338
            foreach($questions as $question)
3339
            {
3340
                $record_answers = [];
3341
 
3342
                $answers = $answerMapper->fetchAllByQuizIdAndQuestionId($question->quiz_id, $question->id);
3343
                foreach($answers as $answer)
3344
                {
3345
                    array_push($record_answers, [
3346
                        'uuid' => $answer->uuid,
3347
                        'text' => trim($answer->text),
3348
                        'correct' => $answer->correct ? $answer->correct  : 0 ,
3349
                        'points' => intval($answer->points, 10),
3350
                    ]);
3351
                }
3352
 
3353
                array_push($record_questions, [
3354
                    'uuid' => $question->uuid,
3355
                    'text' => trim($question->text),
3356
                    'type' => $question->type,
3357
                    'maxlength' => $question->maxlength,
3358
                    'points' => $question->points,
3359
                    'answers' => $record_answers,
3360
                ]);
3361
            }
3362
 
3363
 
3364
            array_push($data['quizzes'], [
3365
                'uuid' => $quiz->uuid,
3366
                'name' => $quiz->name,
3367
                'text' => trim($quiz->text ? $quiz->text : ''),
3368
                'failed' => trim($quiz->failed ? $quiz->failed : ''),
3369
                'points' => $quiz->points,
3370
                'minimum_points_required' => $quiz->minimum_points_required,
3371
                'max_time' => $quiz->max_time ? $quiz->max_time : 5,
3372
                'company_uuid' => $company->uuid,
3373
                'company_name' => $company->name,
3374
                'company_image' => $this->url()->fromRoute('services/storage',['type' => 'company', 'code' => $company->uuid, 'filename' => $company->image], ['force_canonical' => true]),
3375
                'questions' => $record_questions,
3376
            ]);
3377
        }
47 efrain 3378
 
3379
        $companyExtendUserMapper = CompanyMicrolearningExtendUserMapper::getInstance($this->adapter);
3380
        $companyExtendUserCompanyMapper = CompanyMicrolearningExtendUserCompanyMapper::getInstance($this->adapter);
3381
        $companyExtendUserFunctionMapper = CompanyMicrolearningExtendUserFunctionMapper::getInstance($this->adapter);
3382
        $companyExtendUserGroupMapper = CompanyMicrolearningExtendUserGroupMapper::getInstance($this->adapter);
3383
        $companyExtendUserInstitutionMapper = CompanyMicrolearningExtendUserInstitutionMapper::getInstance($this->adapter);
3384
        $companyExtendUserPartnerMapper = CompanyMicrolearningExtendUserPartnerMapper::getInstance($this->adapter);
3385
        $companyExtendUserProgramMapper = CompanyMicrolearningExtendUserProgramMapper::getInstance($this->adapter);
3386
        $companyExtendUserStudentTypeMapper = CompanyMicrolearningExtendUserStudentTypeMapper::getInstance($this->adapter);
3387
        $companyExtendUserSectorMapper = CompanyMicrolearningExtendUserSectorMapper::getInstance($this->adapter);
3388
 
3389
        $companyServiceMapper = CompanyServiceMapper::getInstance($this->adapter);
3390
        foreach($companies_with_access as $company_id)
3391
        {
3392
            $companyService =  $companyServiceMapper->fetchOneActiveByCompanyIdAndServiceId($company_id, Service::MICRO_LEARNING);
3393
 
3394
            //print_r($companyService); exit;
3395
 
3396
            if(!$companyService) {
3397
                continue;
3398
            }
3399
 
3400
 
3401
            if(isset($companies[$companyService->company_id])) {
3402
                $company = $companies[$companyService->company_id];
3403
            } else {
3404
                $company = $companyMapper->fetchOne($companyService->company_id);
3405
                $companies[$companyService->company_id] = $company;
3406
            }
3407
 
3408
            if(!$company) {
3409
                continue;
3410
            }
3411
 
3412
            $record = [
3413
                'company_uuid' => $company->uuid,
3414
                'company_name' => $company->name,
3415
                'company_image' => $this->url()->fromRoute('services/storage',['type' => 'company', 'code' => $company->uuid, 'filename' => $company->image], ['force_canonical' => true]),
48 efrain 3416
                'details' => [],
47 efrain 3417
            ];
3418
 
3419
            $companyExtendUser = $companyExtendUserMapper->fetchOneByCompanyIdAndUserId($company->id, $user->id);
3420
            if(!$companyExtendUser) {
3421
                continue;
3422
            }
3423
 
3424
            if($companyExtendUser->extend_company_id) {
3425
 
3426
                $extendedCompany = $companyExtendUserCompanyMapper->fetchOne($companyExtendUser->company_id);
3427
                if($extendedCompany) {
48 efrain 3428
                    array_push($record['details'],[
3429
                        'uuid' => $extendedCompany->uuid,
3430
                        'label' => 'LABEL_COMPANY',
3431
                        'value' => $extendedCompany->name
3432
                    ]);
47 efrain 3433
                }
3434
            }
3435
 
3436
            if($companyExtendUser->extend_function_id) {
3437
                $extendedFunction = $companyExtendUserFunctionMapper->fetchOne($companyExtendUser->extend_function_id);
3438
                if($extendedFunction) {
48 efrain 3439
                    array_push($record['details'],[
3440
                        'uuid' => $extendedFunction->uuid,
3441
                        'label' => 'LABEL_FUNCTION',
3442
                        'value' => $extendedFunction->name
3443
                    ]);
47 efrain 3444
                }
3445
            }
3446
 
3447
            if($companyExtendUser->extend_group_id) {
3448
                $extendedGroup = $companyExtendUserGroupMapper->fetchOne($companyExtendUser->extend_group_id);
3449
                if($extendedGroup) {
48 efrain 3450
                    array_push($record['details'],[
3451
                        'uuid' => $extendedGroup->uuid,
3452
                        'label' => 'LABEL_GROUP',
3453
                        'value' => $extendedGroup->name
3454
                    ]);
47 efrain 3455
                }
3456
            }
3457
 
3458
            if($companyExtendUser->extend_institution_id) {
3459
                $extendedInstitution= $companyExtendUserInstitutionMapper->fetchOne($companyExtendUser->extend_institution_id);
3460
                if($extendedInstitution) {
48 efrain 3461
                    array_push($record['details'],[
3462
                        'uuid' => $extendedInstitution->uuid,
3463
                        'label' => 'LABEL_INSTITUTION',
3464
                        'value' => $extendedInstitution->name
3465
                    ]);
47 efrain 3466
                }
3467
            }
3468
 
3469
            if($companyExtendUser->extend_program_id) {
3470
                $extendedProgram = $companyExtendUserProgramMapper->fetchOne($companyExtendUser->extend_program_id);
3471
                if($extendedProgram) {
48 efrain 3472
                    array_push($record['details'],[
3473
                        'uuid' => $extendedProgram->uuid,
3474
                        'label' => 'LABEL_PROGRAM',
3475
                        'value' => $extendedProgram->name
3476
                    ]);
3477
 
47 efrain 3478
                }
3479
            }
3480
 
3481
            if($companyExtendUser->extend_sector_id) {
3482
                $extendedSector = $companyExtendUserSectorMapper->fetchOne($companyExtendUser->extend_sector_id);
3483
                if($extendedSector) {
48 efrain 3484
                    array_push($record['details'],[
3485
                        'uuid' => $extendedSector->uuid,
3486
                        'label' => 'LABEL_SECTOR',
3487
                        'value' => $extendedSector->name
3488
                    ]);
47 efrain 3489
                }
3490
            }
3491
 
3492
            if($companyExtendUser->extend_partner_id) {
3493
                $extendedPartner = $companyExtendUserPartnerMapper->fetchOne($companyExtendUser->extend_partner_id);
3494
                if($extendedPartner) {
48 efrain 3495
                    array_push($record['details'],[
3496
                        'uuid' => $extendedPartner->uuid,
3497
                        'label' => 'LABEL_PARTNER',
3498
                        'value' => $extendedPartner->name
3499
                    ]);
47 efrain 3500
                }
3501
            }
3502
 
3503
            if($companyExtendUser->extend_student_type_id) {
3504
                $extendedStudentType = $companyExtendUserStudentTypeMapper->fetchOne($companyExtendUser->extend_student_type_id);
3505
                if($extendedStudentType) {
48 efrain 3506
                    array_push($record['details'],[
3507
                        'uuid' => $extendedStudentType->uuid,
3508
                        'label' => 'LABEL_TYPE',
3509
                        'value' => $extendedStudentType->name
3510
                    ]);
47 efrain 3511
                }
3512
            }
3513
 
3514
            array_push($data['extended'], $record);
3515
        }
3516
 
1 www 3517
        return $data;
3518
    }
3519
 
3520
 
3521
    /**
3522
     *
3523
     * @param string $filename
3524
     * @param boolean $retbytes
3525
     * @return boolean|number
3526
     */
3527
    private function readfile_chunked($filename, $retbytes = true) {
3528
        $buffer = '';
3529
        $cnt =0;;
3530
        $handle = fopen($filename,'rb');
3531
        if ($handle === false) {
3532
            return false;
3533
        }
3534
        while (!feof($handle)) {
3535
            $buffer = fread($handle, self::CHUNK_SIZE);
3536
            echo $buffer;
3537
            ob_flush();
3538
            flush();
3539
            if ($retbytes) {
3540
                $cnt += strlen($buffer);
3541
            }
3542
        }
3543
        $status = fclose($handle);
3544
        if ($retbytes && $status) {
3545
            return $cnt; // return num. bytes delivered like readfile() does.
3546
        }
3547
        return $status;
3548
    }
3549
}