Proyectos de Subversion LeadersLinked - Backend

Rev

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