Proyectos de Subversion LeadersLinked - Backend

Rev

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