Proyectos de Subversion LeadersLinked - Backend

Rev

Rev 8394 | Rev 8397 | 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
/**
3
 *
4
 * Controlador: Mis Perfiles
5
 *
6
 */
7
declare(strict_types=1);
8
 
9
namespace LeadersLinked\Controller;
10
 
11
use Laminas\Db\Adapter\AdapterInterface;
12
use Laminas\Cache\Storage\Adapter\AbstractAdapter;
13
use Laminas\Mvc\Controller\AbstractActionController;
14
use Laminas\Log\LoggerInterface;
15
use Laminas\View\Model\ViewModel;
16
use Laminas\View\Model\JsonModel;
17
 
18
use LeadersLinked\Mapper\CompanyMapper;
19
use LeadersLinked\Mapper\CompanyUserMapper;
20
use LeadersLinked\Form\CreateFeedForm;
21
use LeadersLinked\Form\CommentForm;
22
use LeadersLinked\Model\Comment;
23
use LeadersLinked\Mapper\CommentMapper;
24
use LeadersLinked\Mapper\FeedMapper;
25
use LeadersLinked\Mapper\GroupMapper;
26
use LeadersLinked\Model\Feed;
27
use LeadersLinked\Mapper\QueryMapper;
28
use LeadersLinked\Hydrator\ObjectPropertyHydrator;
29
use LeadersLinked\Library\Image;
30
use LeadersLinked\Model\VideoConvert;
31
use LeadersLinked\Mapper\VideoConvertMapper;
32
use LeadersLinked\Mapper\LikeMapper;
33
use Laminas\Paginator\Adapter\DbSelect;
34
use Laminas\Paginator\Paginator;
35
use LeadersLinked\Mapper\UserMapper;
36
use LeadersLinked\Library\Functions;
37
use LeadersLinked\Model\Company;
38
use LeadersLinked\Model\UserType;
39
 
7643 nelberth 40
use LeadersLinked\Mapper\HighPerformanceTeamsGroupsViewTopicMapper;
7381 nelberth 41
use LeadersLinked\Model\HighPerformanceTeamsGroupsMembers;
42
use LeadersLinked\Model\HighPerformanceTeamsGroups;
43
use LeadersLinked\Mapper\HighPerformanceTeamsGroupsMembersMapper;
44
use LeadersLinked\Mapper\HighPerformanceTeamsGroupsMapper;
45
 
1 www 46
class FeedController extends AbstractActionController
47
{
48
    /**
49
     *
50
     * @var AdapterInterface
51
     */
52
    private $adapter;
53
 
54
 
55
    /**
56
     *
57
     * @var AbstractAdapter
58
     */
59
    private $cache;
60
 
61
    /**
62
     *
63
     * @var  LoggerInterface
64
     */
65
    private $logger;
66
 
67
 
68
    /**
69
     *
70
     * @var array
71
     */
72
    private $config;
73
 
74
    /**
75
     *
76
     * @param AdapterInterface $adapter
77
     * @param AbstractAdapter $cache
78
     * @param LoggerInterface $logger
79
     * @param array $config
80
     */
81
    public function __construct($adapter, $cache , $logger,  $config)
82
    {
83
        $this->adapter      = $adapter;
84
        $this->cache        = $cache;
85
        $this->logger       = $logger;
86
        $this->config       = $config;
87
 
88
    }
89
 
90
    /**
91
     *
92
     * Generación del listado de perfiles
93
     * {@inheritDoc}
94
     * @see \Laminas\Mvc\Controller\AbstractActionController::indexAction()
95
     */
96
    public function indexAction()
97
    {
98
        $currentUserPlugin = $this->plugin('currentUserPlugin');
99
        $currentUser = $currentUserPlugin->getUser();
100
        $currentCompany = $currentUserPlugin->getCompany();
101
 
102
 
103
 
104
        $request = $this->getRequest();
105
        if($request->isGet()) {
106
            $headers  = $request->getHeaders();
107
 
108
            $isJson = false;
109
            if($headers->has('Accept')) {
110
                $accept = $headers->get('Accept');
111
 
112
                $prioritized = $accept->getPrioritized();
113
 
114
                foreach($prioritized as $key => $value) {
115
                    $raw = trim($value->getRaw());
116
 
117
                    if(!$isJson) {
118
                        $isJson = strpos($raw, 'json');
119
                    }
120
 
121
                }
122
            }
123
 
7645 nelberth 124
            $formFeed = new CreateFeedForm($this->adapter);
1 www 125
 
126
            $this->layout()->setTemplate('layout/layout-backend');
127
            $viewModel = new ViewModel();
128
            $viewModel->setTemplate('leaders-linked/feeds/index.phtml');
129
            $viewModel->setVariables([
130
                'formFeed'      => $formFeed,
131
            ]);
132
            return $viewModel ;
133
 
134
 
135
        } else {
136
            return new JsonModel([
137
                'success' => false,
138
                'data' => 'ERROR_METHOD_NOT_ALLOWED'
139
            ]);
140
        }
141
    }
142
 
143
 
144
    public function commentAction()
145
    {
8396 nelberth 146
 
8394 nelberth 147
 
1 www 148
        $currentUserPlugin = $this->plugin('currentUserPlugin');
149
        $currentUser = $currentUserPlugin->getUser();
150
        $currentCompany = $currentUserPlugin->getCompany();
151
 
152
 
153
        $id = $this->params()->fromRoute('id');
154
 
155
        $request = $this->getRequest();
156
        if($request->isPost()) {
157
            $feedMapper = FeedMapper::getInstance($this->adapter);
158
            $feed = $feedMapper->fetchOneByUuid($id);
159
            if(!$feed) {
160
                $response = [
161
                    'success' => false,
162
                    'data' => 'ERROR_POST_NOT_FOUND'
163
                ];
164
                return new JsonModel($response);
165
            }
166
 
167
            if($feed->company_id != $currentCompany->id) {
168
                $response = [
169
                    'success' => false,
170
                    'data' => 'ERROR_UNAUTHORIZED'
171
                ];
172
                return new JsonModel($response);
173
            }
174
 
175
            $dataPost = $request->getPost()->toArray();
176
            $form = new CommentForm();
177
            $form->setData($dataPost);
178
 
179
            if($form->isValid()) {
180
                $companyUserMapper = CompanyUserMapper::getInstance($this->adapter);
181
                $owner = $companyUserMapper->fetchOwnerByCompanyId($currentCompany->id);
182
 
183
                $dataPost = (array) $form->getData();
184
                $comment = new Comment();
185
                $comment->comment = $dataPost['comment'];
186
                $comment->feed_id = $feed->id;
187
 
8232 nelberth 188
                if($feed->type=='hptg'){
189
                    $comment->user_id = $currentUser->id;
190
 
191
                }else{
192
                    $comment->user_id = $owner->user_id;
193
 
194
                }
195
 
1 www 196
                $commentMapper = CommentMapper::getInstance($this->adapter);
197
                if($commentMapper->insert($comment)) {
198
 
199
                    $total_comments = $commentMapper->fetchCountCommentByFeedId($comment->feed_id);
200
 
201
                    $feed->total_comments = $total_comments;
202
                    $feedMapper->update($feed);
203
 
204
                    $response = [
205
                        'success'   => true,
206
                        'data'   => $this->renderComment($comment->id),
207
                        'total_comments' => $total_comments
208
                    ];
209
 
210
                    return new JsonModel($response);
211
 
212
                } else {
213
 
214
                    $response = [
215
                        'success'   => false,
216
                        'data'   => $commentMapper->getError()
217
                    ];
218
 
219
                    return new JsonModel($response);
220
                }
221
 
222
            } else {
223
                $message = '';;
224
                $form_messages = (array) $form->getMessages();
225
                foreach($form_messages  as $fieldname => $field_messages)
226
                {
227
                    foreach( $field_messages as $key => $value)
228
                    {
229
                        $message = $value;
230
                    }
231
                }
232
 
233
                $response = [
234
                    'success'   => false,
235
                    'data'   => $message
236
                ];
237
 
238
                return new JsonModel($response);
239
            }
240
 
241
 
242
        } else {
243
            $response = [
244
                'success' => false,
245
                'data' => 'ERROR_METHOD_NOT_ALLOWED'
246
            ];
247
 
248
            return new JsonModel($response);
249
        }
250
 
251
 
252
    }
8390 nelberth 253
 
254
 
1 www 255
 
256
 
257
    public function commentDeleteAction()
258
    {
259
        $currentUserPlugin = $this->plugin('currentUserPlugin');
260
        $currentUser = $currentUserPlugin->getUser();
261
        $currentCompany = $currentUserPlugin->getCompany();
262
 
263
        $request = $this->getRequest();
264
        if($request->isPost()) {
265
            $currentUserPlugin = $this->plugin('currentUserPlugin');
266
            $currentUser = $currentUserPlugin->getUser();
267
 
268
            $id = $this->params()->fromRoute('id');
269
            $comment = $this->params()->fromRoute('comment');
270
 
271
            $feedMapper = FeedMapper::getInstance($this->adapter);
272
            $feed = $feedMapper->fetchOneByUuid($id);
273
            if(!$feed) {
274
                $response = [
275
                    'success' => false,
276
                    'data' => 'ERROR_POST_NOT_FOUND'
277
                ];
278
                return new JsonModel($response);
279
            }
280
 
281
            if($feed->company_id != $currentCompany->id) {
282
                $response = [
283
                    'success' => false,
284
                    'data' => 'ERROR_UNAUTHORIZED'
285
                ];
286
                return new JsonModel($response);
287
            }
288
 
289
            $commentMapper = CommentMapper::getInstance($this->adapter);
290
            $comment = $commentMapper->fetchOneByUuid($comment);
291
 
292
            if($comment && $comment->feed_id == $feed->id) {
293
                $comment->status = Comment::STATUS_DELETED;
294
                if($commentMapper->update($comment)) {
295
                    $total_comments = $commentMapper->fetchCountCommentByFeedId($comment->feed_id);
296
 
297
                    $feed = $feedMapper->fetchOne($comment->feed_id);
298
                    $feed->total_comments = $total_comments;
299
                    $feedMapper->update($feed);
300
 
301
 
302
 
303
 
304
 
305
                    $response = [
306
                        'success' => true,
307
                        'data' => [
308
                            'message' => 'LABEL_COMMENT_WAS_DELETED',
309
                            'total_comments' => $total_comments
310
                        ]
311
                   ];
312
                } else {
313
                    $response = [
314
                        'success' => false,
315
                        'data' => $commentMapper->getError()
316
                    ];
317
                }
318
 
319
            } else {
320
                $response = [
321
                    'success' => false,
322
                    'data' => 'ERROR_COMMENT_NOT_FOUND'
323
                ];
324
            }
325
 
326
        } else {
327
            $response = [
328
                'success' => false,
329
                'data' => 'ERROR_METHOD_NOT_ALLOWED'
330
            ];
331
        }
332
 
333
        return new JsonModel($response);
334
    }
335
 
336
    public function deleteAction()
337
    {
338
        $currentUserPlugin = $this->plugin('currentUserPlugin');
339
        $currentUser = $currentUserPlugin->getUser();
340
        $currentCompany = $currentUserPlugin->getCompany();
341
 
342
        $request = $this->getRequest();
343
        if($request->isPost()) {
344
 
345
 
346
            $id =  $this->params()->fromRoute('id');
347
 
348
            $feedMapper = FeedMapper::getInstance($this->adapter);
349
            $feed = $feedMapper->fetchOneByUuid($id);
350
            if(!$feed) {
351
                $response = [
352
                    'success' => false,
353
                    'data' => 'ERROR_POST_NOT_FOUND'
354
                ];
355
                return new JsonModel($response);
356
            }
357
 
358
            if($feed->company_id != $currentCompany->id) {
359
                $response = [
360
                    'success' => false,
361
                    'data' => 'ERROR_UNAUTHORIZED'
362
                ];
363
                return new JsonModel($response);
364
            }
365
 
366
            $feedMapper = FeedMapper::getInstance($this->adapter);
367
            $feed->status = Feed::STATUS_DELETED;
368
            if($feedMapper->update($feed)) {
369
                $response = [
370
                    'success' => true,
371
                    'data' => 'LABEL_FEED_WAS_DELETED'
372
                ];
373
 
374
            } else {
375
                $response = [
376
                    'success' => false,
377
                    'data' => $feedMapper->getError()
378
                ];
379
            }
380
 
381
 
382
            return new JsonModel($response);
383
 
384
        } else {
385
            $response = [
386
                'success' => false,
387
                'data' => 'ERROR_METHOD_NOT_ALLOWED'
388
            ];
389
        }
390
 
391
        return new JsonModel($response);
392
    }
393
 
394
    public function addAction()
395
    {
396
        $currentUserPlugin = $this->plugin('currentUserPlugin');
397
        $currentUser = $currentUserPlugin->getUser();
398
        $currentCompany = $currentUserPlugin->getCompany();
7403 nelberth 399
 
400
 
401
        $request = $this->getRequest();
402
        if($request->isPost()) {
7653 nelberth 403
 
404
 
405
            $dataPost = array_merge($request->getPost()->toArray(), $request->getFiles()->toArray());
406
 
407
            $form = new CreateFeedForm($this->adapter);
7654 nelberth 408
 
1 www 409
            $form->setData($dataPost);
7673 nelberth 410
 
1 www 411
            if($form->isValid()) {
412
 
7680 nelberth 413
 
1 www 414
                $companyMapper = CompanyMapper::getInstance($this->adapter);
415
                $company = $companyMapper->fetchOne($currentCompany->id);
416
 
417
                $companyUserMapper = CompanyUserMapper::getInstance($this->adapter);
418
                $owner = $companyUserMapper->fetchOwnerByCompanyId($company->id);
419
 
7408 nelberth 420
 
421
 
7652 nelberth 422
 
1 www 423
                $hydrator = new ObjectPropertyHydrator();
424
                $feed = new Feed();
425
                $hydrator->hydrate($dataPost, $feed);
7407 nelberth 426
                if($feed->type=='hptg'){
427
 
7411 nelberth 428
                    $group_id =  $this->params()->fromRoute('group_id');
7409 nelberth 429
                    $highPerformanceTeamsGroupsMapper = HighPerformanceTeamsGroupsMapper::getInstance($this->adapter);
7411 nelberth 430
                    $highPerformanceTeamsGroups = $highPerformanceTeamsGroupsMapper->fetchOneByUuid($group_id);
7414 nelberth 431
 
7409 nelberth 432
                    if (!$highPerformanceTeamsGroups) {
433
                        $data = [
434
                            'success' => false,
7414 nelberth 435
                            'data' => 'ERROR_RECORD_NOT_FOUND'
7409 nelberth 436
                        ];
7407 nelberth 437
 
7409 nelberth 438
                        return new JsonModel($data);
439
                    }
440
 
441
                    if($highPerformanceTeamsGroups->status != HighPerformanceTeamsGroups::STATUS_ACTIVE) {
442
 
443
                        return new JsonModel([
444
                            'success' => false,
7414 nelberth 445
                            'data' => 'ERROR_UNAUTHORIZED'
7409 nelberth 446
                        ]);
447
 
448
                    }
449
 
450
                    $highPerformanceTeamsGroupsMemberMapper = HighPerformanceTeamsGroupsMembersMapper::getInstance($this->adapter);
451
                    $highPerformanceTeamsGroupsMember = $highPerformanceTeamsGroupsMemberMapper->fetchOneByGroupIdAndUserId($highPerformanceTeamsGroups->id, $currentUser->id);
452
                    if($highPerformanceTeamsGroupsMember) {
7413 nelberth 453
                        if($highPerformanceTeamsGroupsMember->status == HighPerformanceTeamsGroupsMembers::STATUS_ACCEPTED || $highPerformanceTeamsGroupsMember->status == HighPerformanceTeamsGroupsMembers::STATUS_ADDED_BY_ADMIN ){
454
                            $id =  $highPerformanceTeamsGroups->id;
455
                        }else{
456
 
457
                            return new JsonModel([
458
                                'success' => false,
459
                                'data' => 'ERROR_UNAUTHORIZED'
460
                            ]);
461
                        }
7409 nelberth 462
 
463
                    } else {
464
 
465
                        return new JsonModel([
466
                            'success' => false,
7414 nelberth 467
                            'data' => 'ERROR_RECORD_NOT_FOUND'
7409 nelberth 468
                        ]);
469
                    }
7644 nelberth 470
 
7649 nelberth 471
                    if(isset($dataPost['high_performance_group_topic_id'])){
7651 nelberth 472
 
7644 nelberth 473
                        $highPerformanceTeamsGroupsViewTopicMapper = HighPerformanceTeamsGroupsViewTopicMapper::getInstance($this->adapter);
7649 nelberth 474
                        $highPerformanceTeamsGroupsViewTopic = $highPerformanceTeamsGroupsViewTopicMapper->fetchOneByUuid($dataPost['high_performance_group_topic_id']);
7644 nelberth 475
                        if($highPerformanceTeamsGroupsViewTopic){
476
                            $feed->high_performance_group_topic_id = $highPerformanceTeamsGroupsViewTopic->id;
477
                        }else{
478
                            return new JsonModel([
479
                                'success' => false,
480
                                'data' => 'ERROR_RECORD_NOT_FOUND'
481
                            ]);
482
                        }
483
                    }
7409 nelberth 484
 
485
 
486
                    $feed->company_id       = $currentCompany->id;
487
                    $feed->group_id         = null;
488
                    $feed->high_performance_group_id = $id;
8222 nelberth 489
                    $feed->user_id          = $currentUser->id;
7409 nelberth 490
                    $feed->type             = Feed::TYPE_HPTG;
491
                    $feed->posted_or_shared = Feed::POSTED;
492
                    $feed->shared_with      = Feed::SHARE_WITH_CONNECTIONS;
493
 
7407 nelberth 494
                }else{
495
                    $feed->company_id       = $currentCompany->id;
496
                    $feed->group_id         = null;
497
                    $feed->user_id          = $owner->user_id;
498
                    $feed->type             = Feed::TYPE_COMPANY;
499
                    $feed->posted_or_shared = Feed::POSTED;
500
                    $feed->shared_with      = Feed::SHARE_WITH_CONNECTIONS;
501
                }
1 www 502
 
503
 
504
 
505
 
506
 
507
                $feed->total_comments   = 0;
508
                $feed->total_shared     = 0;
509
 
510
 
511
                $files = $this->getRequest()->getFiles()->toArray();
512
                $file_type = '';
513
                if(isset($files['file']) && empty($files['file']['error'])) {
514
                    $feed_tmp_filename  = $files['file']['tmp_name'];
515
                    $feed_filename      = $this->normalizeString($files['file']['name']);
516
 
517
                    $mime_type = mime_content_type($feed_tmp_filename);
518
                    if($mime_type == 'image/jpg' || $mime_type == 'image/jpeg' || $mime_type == 'image/png') {
519
                        $file_type = Feed::FILE_TYPE_IMAGE;
520
                    } else if($mime_type == 'video/webm' || $mime_type == 'video/mpeg' || $mime_type == 'video/mpg' || $mime_type == 'video/mp4') {
521
                        $file_type = Feed::FILE_TYPE_VIDEO;
522
                    } else if($mime_type == 'application/pdf') {
523
                        $file_type = Feed::FILE_TYPE_DOCUMENT;
524
                    }
525
                }
526
 
527
                $feedMapper = FeedMapper::getInstance($this->adapter);
528
                $result = $feedMapper->insert($feed);
529
                if($result) {
530
                    $feed = $feedMapper->fetchOne($feed->id);
531
 
532
                    if( $file_type == Feed::FILE_TYPE_DOCUMENT) {
533
                        try {
534
                            $target_path = $this->config['leaderslinked.fullpath.feed'] . $feed->uuid;
535
                            if(!file_exists($target_path)) {
536
                                mkdir($target_path, 0755);
537
                            }
538
 
539
                            $full_filename = $target_path  . DIRECTORY_SEPARATOR .$feed_filename;
540
                            $result = move_uploaded_file($feed_tmp_filename , $full_filename);
541
                            if($result) {
542
 
543
                                $feed->file_type = $file_type;
544
                                $feed->file_name = basename($feed_filename);
545
                                $feedMapper->update($feed);
546
                            } else {
547
                                error_log('no se pudo mover o renombrar el documento : ' . $feed_tmp_filename . ' al directorio : ' . $full_filename );
548
                            }
549
                        } catch(\Throwable $e) {
550
                            error_log($e->getTraceAsString());
551
                        }
552
                    }
553
                    if( $file_type == Feed::FILE_TYPE_IMAGE) {
554
                        try {
555
                            $target_path = $this->config['leaderslinked.fullpath.feed'] . $feed->uuid;
556
                            if(!file_exists($target_path)) {
557
                                mkdir($target_path, 0755);
558
                            }
559
 
560
                            list($target_width, $target_height) = explode('x', $this->config['leaderslinked.image_sizes.feed_image_size']);
561
 
562
                            $feed_filename = substr($feed_filename, 0, strrpos($feed_filename, '.'))  . '.png';
563
                            $crop_to_dimensions = false;
564
                            if(Image::uploadImage($feed_tmp_filename, $target_path, $feed_filename, $target_width, $target_height, $crop_to_dimensions )) {
565
                                $feed->file_type = $file_type;
566
                                $feed->file_name = basename($feed_filename);
567
                                $feedMapper->update($feed);
568
                            }
569
                        } catch(\Throwable $e) {
570
                            error_log($e->getTraceAsString());
571
                        }
572
                    }
573
                    if( $file_type == Feed::FILE_TYPE_VIDEO) {
574
                        try {
575
                            $target_path = $this->config['leaderslinked.fullpath.feed'] . $feed->uuid;
576
                            if(!file_exists($target_path)) {
577
                                mkdir($target_path, 0755);
578
                            }
579
 
580
                            $full_filename = $target_path  . DIRECTORY_SEPARATOR . $feed_filename;
581
 
582
                            $result = move_uploaded_file($feed_tmp_filename , $full_filename);
583
                            if($result) {
584
 
585
                                $size = $this->config['leaderslinked.image_sizes.feed_image_size'];
586
                                $getFromSecound = 2;
587
 
588
                                //extracción del cover
589
                                $generateFileName = substr($feed_filename, 0, strrpos($feed_filename, '.'));
590
                                $generateFile =  $target_path  . DIRECTORY_SEPARATOR . $generateFileName .  '.png';
591
                                $cmd            = "/usr/bin/ffmpeg -i $full_filename -an -ss $getFromSecound -s $size $generateFile";
592
                                exec($cmd);
593
 
594
 
595
                                $feed->file_type = $file_type;
596
                                $feed->file_name = basename($feed_filename);
597
                                $feed->file_image_preview = basename($generateFile);
598
                                $feedMapper->update($feed);
599
 
600
                                $videoConvert = new VideoConvert();
601
                                $videoConvert->filename = $full_filename;
602
                                $videoConvert->type = VideoConvert::TYPE_FEED;
603
 
604
                                $videoConvertMapper = VideoConvertMapper::getInstance($this->adapter);
605
                                $videoConvertMapper->insert($videoConvert);
606
                            } else {
607
                                error_log('no se pudo mover o renombrar el documento : ' . $feed_tmp_filename . ' al directorio : ' . $full_filename );
608
                            }
609
                        } catch(\Throwable $e) {
610
                            error_log($e->getTraceAsString());
611
                        }
612
                    }
613
 
614
 
615
                    $response = [
616
                        'success'   => true,
617
                        'data'   => $this->renderFeed($feed->id)
618
                    ];
619
                } else {
620
                    $response = [
621
                        'success'   => false,
622
                        'data'   => $feedMapper->getError()
623
                    ];
624
                }
625
            } else {
626
                $messages = [];
627
                $form_messages = (array) $form->getMessages();
628
                foreach($form_messages  as $fieldname => $field_messages)
629
                {
630
                    $messages[$fieldname] = array_values($field_messages);
631
                }
632
 
633
                $response = [
634
                    'success'   => false,
635
                    'data'   => $messages
636
                ];
637
            }
638
 
639
        } else {
640
            $response = [
641
                'success' => false,
642
                'data' => 'ERROR_METHOD_NOT_ALLOWED'
643
            ];
644
        }
645
 
646
        return new JsonModel($response);
647
    }
648
 
649
    public function post($dataPost)
650
    {
651
 
652
 
653
 
654
 
655
 
656
    }
657
 
658
 
659
 
660
    public function timelineAction()
661
    {
662
        $currentUserPlugin = $this->plugin('currentUserPlugin');
663
        $currentUser = $currentUserPlugin->getUser();
664
        $currentCompany = $currentUserPlugin->getCompany();
7366 nelberth 665
 
7372 nelberth 666
 
7381 nelberth 667
 
7378 nelberth 668
 
7357 nelberth 669
 
7366 nelberth 670
        $request = $this->getRequest();
1 www 671
        if($request->isGet()) {
672
 
673
            $page = (int) $this->params()->fromQuery('page');
7374 nelberth 674
            $type   = $this->params()->fromRoute('type');
7837 nelberth 675
            $topic_uuid   = $this->params()->fromRoute('topic_uuid');
7643 nelberth 676
 
7407 nelberth 677
            if(isset($type)&& $type=='hptg'){
7839 nelberth 678
                $id =  $this->params()->fromRoute('id');
7381 nelberth 679
                $highPerformanceTeamsGroupsMapper = HighPerformanceTeamsGroupsMapper::getInstance($this->adapter);
7839 nelberth 680
                $highPerformanceTeamsGroups = $highPerformanceTeamsGroupsMapper->fetchOneByUuid($id);
7425 nelberth 681
 
7414 nelberth 682
                if (!$highPerformanceTeamsGroups) {
683
                    $data = [
684
                        'success' => false,
685
                        'data' => 'ERROR_RECORD_NOT_FOUND'
686
                    ];
687
 
688
                    return new JsonModel($data);
689
                }
690
 
691
                if($highPerformanceTeamsGroups->status != HighPerformanceTeamsGroups::STATUS_ACTIVE) {
692
 
693
                    return new JsonModel([
694
                        'success' => false,
695
                        'data' => 'ERROR_UNAUTHORIZED'
696
                    ]);
697
 
698
                }
699
 
700
                $highPerformanceTeamsGroupsMemberMapper = HighPerformanceTeamsGroupsMembersMapper::getInstance($this->adapter);
701
                $highPerformanceTeamsGroupsMember = $highPerformanceTeamsGroupsMemberMapper->fetchOneByGroupIdAndUserId($highPerformanceTeamsGroups->id, $currentUser->id);
702
                if($highPerformanceTeamsGroupsMember) {
703
                    if($highPerformanceTeamsGroupsMember->status == HighPerformanceTeamsGroupsMembers::STATUS_ACCEPTED || $highPerformanceTeamsGroupsMember->status == HighPerformanceTeamsGroupsMembers::STATUS_ADDED_BY_ADMIN ){
7701 nelberth 704
                        $queryMapper = QueryMapper::getInstance($this->adapter);
705
                        $select = $queryMapper->getSql()->select(FeedMapper::_TABLE);
706
                        $select->columns(['id']);
707
                        $select->where->equalTo('status', Feed::STATUS_PUBLISHED);
708
                        $select->where->equalTo('company_id',$currentCompany->id);
709
                        $select->where->equalTo('high_performance_group_id',$highPerformanceTeamsGroups->id);
7420 nelberth 710
 
7643 nelberth 711
                        if(isset($topic_uuid)){
712
                            $highPerformanceTeamsGroupsViewTopicMapper = HighPerformanceTeamsGroupsViewTopicMapper::getInstance($this->adapter);
713
                            $highPerformanceTeamsGroupsViewTopic = $highPerformanceTeamsGroupsViewTopicMapper->fetchOneByUuid($topic_uuid);
714
                            if($highPerformanceTeamsGroupsViewTopic){
7766 nelberth 715
                                if($highPerformanceTeamsGroupsViewTopic->status!='a'){
716
                                    return new JsonModel([
717
                                        'success' => false,
718
                                        'data' => 'ERROR_YOU_DO_NOT_HAVE_ACCESS'
719
                                    ]);
720
                                }
7701 nelberth 721
                                $select->where->equalTo('high_performance_group_topic_id',$highPerformanceTeamsGroupsViewTopic->id);
722
 
7643 nelberth 723
                            }else{
724
                                return new JsonModel([
725
                                    'success' => false,
726
                                    'data' => 'ERROR_RECORD_NOT_FOUND'
727
                                ]);
728
                            }
7701 nelberth 729
                        }else{
730
                            $select->where->IsNull('high_performance_group_topic_id');
731
 
7643 nelberth 732
                        }
7701 nelberth 733
 
734
 
7420 nelberth 735
                        $select->where->and->equalTo('type', Feed::TYPE_HPTG);
736
                        $select->order('added_on desc');
737
 
7414 nelberth 738
                    }else{
739
                        return new JsonModel([
740
                            'success' => false,
741
                            'data' => 'ERROR_UNAUTHORIZED'
742
                        ]);
743
                    }
744
 
7381 nelberth 745
                } else {
7414 nelberth 746
 
747
                    return new JsonModel([
748
                        'success' => false,
749
                        'data' => 'ERROR_RECORD_NOT_FOUND'
750
                    ]);
7381 nelberth 751
                }
7379 nelberth 752
 
7381 nelberth 753
 
7414 nelberth 754
 
7420 nelberth 755
 
7381 nelberth 756
 
7350 nelberth 757
            }else{
7380 nelberth 758
 
7350 nelberth 759
                $queryMapper = QueryMapper::getInstance($this->adapter);
760
                $select = $queryMapper->getSql()->select(FeedMapper::_TABLE);
761
                $select->columns(['id']);
762
                $select->where->equalTo('status', Feed::STATUS_PUBLISHED);
763
                $select->where->equalTo('company_id',$currentCompany->id);
764
                $select->where->and->equalTo('type', Feed::TYPE_COMPANY);
765
                $select->order('added_on desc');
766
            }
767
 
1 www 768
 
769
 
770
            $dbSelect = new DbSelect($select, $this->adapter);
771
            $paginator = new Paginator($dbSelect);
772
            $paginator->setCurrentPageNumber($page ? $page : 1);
773
            $paginator->setItemCountPerPage(10);
774
 
775
            $items = [];
776
            $feeds = $paginator->getCurrentItems();
777
            foreach($feeds as $feed)
778
            {
779
                $items[] = $this->renderFeed($feed->id);
780
            }
781
 
782
            $response = [
783
                'success' => true,
784
                'data' => [
785
                    'total' => [
786
                        'count' => $paginator->getTotalItemCount(),
787
                        'pages' => $paginator->getPages()->pageCount,
788
                    ],
789
                    'current' => [
790
                        'items'    => $items,
791
                        'page'     => $paginator->getCurrentPageNumber(),
792
                        'count'    => $paginator->getCurrentItemCount(),
793
                    ]
794
                ]
795
            ];
796
 
797
            return new JsonModel($response);
798
        }
799
 
800
        $response = [
801
            'success' => false,
802
            'data' => 'ERROR_METHOD_NOT_ALLOWED'
803
        ];
804
 
805
 
806
        return new JsonModel($response);
807
    }
808
 
809
    /**
810
     *
811
     * @param string $str
812
     * @return string
813
     */
814
    private function normalizeString ($str = '')
815
    {
816
        $basename  = substr($str, 0, strrpos($str, '.'));
817
        $basename  = str_replace('.', '-', $basename);
818
 
819
        $extension  = substr($str, strrpos($str, '.'));
820
 
821
        $str = $basename . $extension;
822
 
823
        $str = strip_tags($str);
824
        $str = preg_replace('/[\r\n\t ]+/', ' ', $str);
825
        $str = preg_replace('/[\"\*\/\:\<\>\?\'\|\,]+/', ' ', $str);
826
        $str = strtolower($str);
827
        $str = html_entity_decode( $str, ENT_QUOTES, "utf-8" );
828
        $str = htmlentities($str, ENT_QUOTES, "utf-8");
829
        $str = preg_replace("/(&)([a-z])([a-z]+;)/i", '$2', $str);
830
        $str = str_replace(' ', '-', $str);
831
        $str = rawurlencode($str);
832
        $str = str_replace('%', '-', $str);
833
        return trim(strtolower($str));
834
    }
835
 
836
 
837
 
838
    /**
839
     *
840
     * @param int $feed_id
841
     * @param Company $company
842
     * @return array
843
     */
844
    private function renderFeed($feed_id)
845
    {
846
 
847
        $sandbox = $this->config['leaderslinked.runmode.sandbox'];
848
        if($sandbox) {
849
            $company_profile_url = $this->config['leaderslinked.frontend.sandbox_company_profile'];
850
            $user_profile_url = $this->config['leaderslinked.frontend.sandbox_user_profile'];
851
 
852
        } else {
853
            $company_profile_url = $this->config['leaderslinked.frontend.production_company_profile'];
854
            $user_profile_url = $this->config['leaderslinked.frontend.production_user_profile'];
855
        }
856
 
857
 
858
 
859
 
860
        $currentUserPlugin = $this->plugin('currentUserPlugin');
861
        $currentUser = $currentUserPlugin->getUser();
862
        $currentCompany = $currentUserPlugin->getCompany();
863
 
864
        $companyMapper = CompanyMapper::getInstance($this->adapter);
865
        $company = $companyMapper->fetchOne($currentCompany->id);
866
 
867
        $companyUserMapper = CompanyUserMapper::getInstance($this->adapter);
868
        $owner = $companyUserMapper->fetchOwnerByCompanyId($currentCompany->id);
869
 
870
 
871
 
872
        $acl = $this->getEvent()->getViewModel()->getVariable('acl');
873
 
874
        $feedMapper = FeedMapper::getInstance($this->adapter);
875
        $feed = $feedMapper->fetchOne($feed_id);
876
 
877
 
878
        $params = [
879
            'id' => $feed->uuid
880
        ];
881
 
882
 
883
        $item = [
884
            'feed_unique' => uniqid(),
885
            'feed_uuid' => $feed->uuid,
8218 nelberth 886
            'feed_delete_url' =>  $this->url()->fromRoute('feeds/delete',  $params),
1 www 887
            'feed_content_type' => $feed->file_type ? $feed->file_type : '',
888
        ];
8205 nelberth 889
        if($feed->type == Feed::TYPE_HPTG)
890
        {
8217 nelberth 891
                $userMapper = UserMapper::getInstance($this->adapter);
892
                $user = $userMapper->fetchOne($feed->user_id);
8224 nelberth 893
                $item['owner_url'] =  str_replace('[uuid]', $user->uuid, $user_profile_url);
8217 nelberth 894
                $item['owner_image'] = $this->url()->fromRoute('storage', ['code' => $user->uuid, 'type' => 'user', 'filename' => $user->image]);
895
                $item['owner_name'] = $user->first_name . ' ' . $user->last_name;
8208 nelberth 896
 
8217 nelberth 897
                if($feed->user_id == $currentUser->id) {
8219 nelberth 898
                    $item['feed_delete_url'] = $this->url()->fromRoute('feeds/delete',  $params);
8217 nelberth 899
                }
8205 nelberth 900
 
901
        } else {
902
            $item['owner_url'] =  str_replace('[uuid]', $company->uuid, $company_profile_url);
903
            $item['owner_image'] = $this->url()->fromRoute('storage', ['code' => $company->uuid, 'type' => 'company', 'filename' => $company->image]);
904
            $item['owner_name'] = $company->name;
905
        }
1 www 906
 
907
        $userMapper = UserMapper::getInstance($this->adapter);
908
        $user = $userMapper->fetchOne($feed->user_id);
909
 
910
 
7235 stevensc 911
        $item['owner_description'] = strip_tags($feed->description, 'p');
1 www 912
        $item['owner_shared'] = $feed->total_shared;
913
        $item['owner_comments'] = $feed->total_comments;
914
 
915
 
916
        $dt = \DateTime::createFromFormat('Y-m-d H:i:s', $feed->added_on);
917
        $item['owner_time_elapse'] = Functions::timeElapsedString( $dt->getTimestamp());
918
 
919
        if($feed->file_type == Feed::FILE_TYPE_IMAGE) {
920
            $item['owner_file_image'] = $this->url()->fromRoute('storage', ['code' => $feed->uuid, 'type' => 'feed', 'filename' => $feed->file_name]);
921
 
922
        }
923
        if($feed->file_type == Feed::FILE_TYPE_DOCUMENT) {
924
            $item['owner_file_document'] = $this->url()->fromRoute('storage', ['code' => $feed->uuid, 'type' => 'feed', 'filename' => $feed->file_name]);
925
        }
926
        if($feed->file_type == Feed::FILE_TYPE_VIDEO) {
927
            $item['owner_file_image_preview'] = $this->url()->fromRoute('storage', ['code' => $feed->uuid, 'type' => 'feed', 'filename' => $feed->file_image_preview]);
928
            $item['owner_file_video'] = $this->url()->fromRoute('storage', ['code' => $feed->uuid, 'type' => 'feed', 'filename' => $feed->file_name]);
929
        }
930
 
931
 
932
 
933
 
934
        $commentMapper = CommentMapper::getInstance($this->adapter);
935
        $records = $commentMapper->fetchAllPublishedByFeedId($feed->id);
936
 
937
 
938
 
939
        $comments = [];
940
        foreach($records as $record)
941
        {
942
            $user = $userMapper->fetchOne($record->user_id);
943
            $dt = \DateTime::createFromFormat('Y-m-d H:i:s', $record->added_on);
944
 
945
            $comment = [];
946
            $comment['unique'] = uniqid();
947
 
948
 
949
            $user = $userMapper->fetchOne($record->user_id);
950
            if($user->id == $owner->user_id) {
951
                $comment['user_image'] = $this->url()->fromRoute('storage', ['type' => 'company',  'code' => $company->uuid, 'filename' =>  $company->image ]);
952
                $comment['user_url'] =  str_replace('[uuid]', $company->uuid, $company_profile_url);
953
                $comment['user_name'] = $company->name;
954
            } else {
955
                $comment['user_image'] = $this->url()->fromRoute('storage', ['type' => 'user',  'code' => $user->uuid, 'filename' =>  $user->image ]);
956
                $comment['user_url'] = str_replace('[uuid]', $user->uuid, $user_profile_url);
957
                $comment['user_name'] = $user->first_name . ' ' . $user->last_name;
958
            }
959
 
960
            $comment['link_delete'] = $this->url()->fromRoute('feeds/comments/delete',['id' => $feed->uuid, 'comment' => $record->uuid ]);
8385 nelberth 961
            $comment['link_answer_add'] = $this->url()->fromRoute('feeds/comments/answer',['id' => $feed->uuid, 'comment' => $record->uuid ]);
1 www 962
            $comment['time_elapsed'] = Functions::timeElapsedString($dt->getTimestamp());
963
            $comment['comment'] = $record->comment;
964
 
965
 
966
 
967
            array_push($comments, $comment);
968
        }
969
        $item['comment_add_url'] = $this->url()->fromRoute('feeds/comments', ['id' => $feed->uuid]);
970
        $item['comments'] = $comments;
971
 
972
        return $item;
973
    }
974
 
975
    /**
976
     *
977
     * @param int $comment_id
978
     * @return array
979
     */
980
    private function renderComment($comment_id)
981
    {
982
        $currentUserPlugin = $this->plugin('currentUserPlugin');
983
        $currentUser = $currentUserPlugin->getUser();
984
        $currentCompany = $currentUserPlugin->getCompany();
985
 
986
        $companyMapper = CompanyMapper::getInstance($this->adapter);
987
        $company = $companyMapper->fetchOne($currentCompany->id);
988
 
989
        $companyUserMapper = CompanyUserMapper::getInstance($this->adapter);
990
        $owner = $companyUserMapper->fetchOwnerByCompanyId($currentCompany->id);
991
 
992
 
993
 
994
        $sandbox = $this->config['leaderslinked.runmode.sandbox'];
995
        if($sandbox) {
996
            $company_profile_url = $this->config['leaderslinked.frontend.sandbox_company_profile'];
997
            $user_profile_url = $this->config['leaderslinked.frontend.sandbox_user_profile'];
998
        } else {
999
            $company_profile_url = $this->config['leaderslinked.frontend.production_company_profile'];
1000
            $user_profile_url = $this->config['leaderslinked.frontend.production_user_profile'];
1001
        }
1002
 
1003
 
1004
        $item = [];
1005
 
1006
        $commentMapper = CommentMapper::getInstance($this->adapter);
1007
        $record = $commentMapper->fetchOne($comment_id);
1008
 
1009
        $feedMapper = FeedMapper::getInstance($this->adapter);
1010
        $feed = $feedMapper->fetchOne($record->feed_id);
1011
 
1012
        if($record) {
1013
            $userMapper = UserMapper::getInstance($this->adapter);
1014
 
1015
            $dt = \DateTime::createFromFormat('Y-m-d H:i:s', $record->added_on);
1016
 
1017
 
1018
            $item = [];
1019
            $item['unique'] = uniqid();
1020
 
1021
 
1022
            $user = $userMapper->fetchOne($record->user_id);
1023
            if($user->id == $owner->user_id) {
1024
                $item['user_image'] = $this->url()->fromRoute('storage', ['type' => 'company',  'code' => $company->uuid, 'filename' =>  $company->image ]);
1025
                $item['user_url'] =  str_replace('[uuid]', $company->uuid, $company_profile_url);
1026
                $item['user_name'] = $company->name;
1027
            } else {
1028
                $item['user_image'] = $this->url()->fromRoute('storage', ['type' => 'user',  'code' => $user->uuid, 'filename' =>  $user->image ]);
1029
                $item['user_url'] = str_replace('[uuid]', $user->uuid, $user_profile_url);
1030
                $item['user_name'] = $user->first_name . ' ' . $user->last_name;
1031
            }
1032
 
1033
 
1034
 
1035
            $item['link_delete'] = $this->url()->fromRoute('feeds/comments/delete',['id' => $feed->uuid, 'comment' => $record->uuid ]);
1036
            $item['time_elapsed'] = Functions::timeElapsedString($dt->getTimestamp());
1037
            $item['comment'] = $record->comment;
1038
 
1039
        }
1040
        return $item;
1041
    }
1042
 
1043
    /**
1044
     *
1045
     * @param string $path
1046
     * @return boolean
1047
     */
1048
    private function deletePath($path)
1049
    {
1050
        try {
1051
            if (is_dir($path)){
1052
                if ($dh = opendir($path)) {
1053
                    while (($file = readdir($dh)) !== false)
1054
                    {
1055
                        if($file == '.' || $file == '..') {
1056
                            continue;
1057
                        }
1058
                        unlink($path . DIRECTORY_SEPARATOR . $file);
1059
                    }
1060
                    closedir($dh);
1061
                }
1062
 
1063
                rmdir($path);
1064
            }
1065
            return true;
1066
        }
1067
        catch (\Throwable $e)
1068
        {
1069
            error_log($e->getTraceAsString());
1070
            return false;
1071
        }
1072
    }
1073
 
1074
}