Proyectos de Subversion LeadersLinked - Backend

Rev

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