Proyectos de Subversion LeadersLinked - Antes de SPA

Rev

Rev 3139 | Rev 3146 | 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\JsonModel;
16
 
17
use LeadersLinked\Library\Functions;
18
use LeadersLinked\Mapper\CompanyUserMapper;
19
use LeadersLinked\Form\Feed\CreateForm;
20
use LeadersLinked\Hydrator\ObjectPropertyHydrator;
21
use LeadersLinked\Model\Feed;
22
use LeadersLinked\Mapper\FeedMapper;
23
use LeadersLinked\Library\Image;
24
use LeadersLinked\Mapper\GroupMapper;
25
use LeadersLinked\Mapper\UserMapper;
26
use LeadersLinked\Mapper\CommentMapper;
27
use LeadersLinked\Mapper\ConnectionMapper;
28
use LeadersLinked\Mapper\CompanyFollowerMapper;
29
use LeadersLinked\Mapper\QueryMapper;
30
use Laminas\Paginator\Paginator;
31
use Laminas\Paginator\Adapter\DbSelect;
32
use LeadersLinked\Mapper\LikeMapper;
33
use LeadersLinked\Model\Like;
34
use LeadersLinked\Form\Feed\CommentForm;
35
use LeadersLinked\Model\Comment;
36
use LeadersLinked\Form\Feed\CreateGroupCompanyForm;
37
use LeadersLinked\Model\CompanyUser;
38
use LeadersLinked\Model\VideoConvert;
39
use LeadersLinked\Mapper\VideoConvertMapper;
40
use LeadersLinked\Mapper\CompanyMapper;
41
use LeadersLinked\Model\Company;
42
use LeadersLinked\Model\Group;
43
use LeadersLinked\Mapper\GroupMemberMapper;
44
use LeadersLinked\Model\GroupMember;
45
use LeadersLinked\Model\Notification;
46
use LeadersLinked\Mapper\NotificationMapper;
47
use LeadersLinked\Mapper\UserNotificationSettingMapper;
48
use LeadersLinked\Mapper\EmailTemplateMapper;
49
use LeadersLinked\Model\EmailTemplate;
50
use LeadersLinked\Library\QueueEmail;
3138 efrain 51
use LeadersLinked\Mapper\UtilMapper;
1 www 52
 
53
 
54
class FeedController extends AbstractActionController
55
{
56
    /**
57
     *
58
     * @var AdapterInterface
59
     */
60
    private $adapter;
61
 
62
 
63
    /**
64
     *
65
     * @var AbstractAdapter
66
     */
67
    private $cache;
68
 
69
    /**
70
     *
71
     * @var  LoggerInterface
72
     */
73
    private $logger;
74
 
75
 
76
    /**
77
     *
78
     * @var array
79
     */
80
    private $config;
81
 
82
    /**
83
     *
84
     * @param AdapterInterface $adapter
85
     * @param AbstractAdapter $cache
86
     * @param LoggerInterface $logger
87
     * @param array $config
88
     */
89
    public function __construct($adapter, $cache , $logger,  $config)
90
    {
91
        $this->adapter      = $adapter;
92
        $this->cache        = $cache;
93
        $this->logger       = $logger;
94
        $this->config       = $config;
95
 
96
    }
97
 
98
    /**
99
     *
100
     * Generación del listado de perfiles
101
     * {@inheritDoc}
102
     * @see \Laminas\Mvc\Controller\AbstractActionController::indexAction()
103
     */
104
    public function indexAction()
105
    {
106
 
107
        return new JsonModel([
108
            'success' => false,
109
            'data' => 'ERROR_METHOD_NOT_ALLOWED'
110
        ]);
111
    }
112
 
113
    public function commentAction()
114
    {
115
        $id = $this->params()->fromRoute('id');
116
 
117
        $request = $this->getRequest();
118
        if($request->isPost()) {
119
            $feedMapper = FeedMapper::getInstance($this->adapter);
120
            $feed = $feedMapper->fetchOneByUuid($id);
121
            if(!$feed) {
122
                $response = [
123
                    'success' => false,
124
                    'data' => 'ERROR_POST_NOT_FOUND'
125
                ];
126
                return new JsonModel($response);
127
            }
128
 
129
            $dataPost = $request->getPost()->toArray();
130
            $form = new CommentForm();
131
            $form->setData($dataPost);
132
 
133
            if($form->isValid()) {
3138 efrain 134
                $utilMapper = UtilMapper::getInstance($this->adapter);
135
                $now = $utilMapper->getDatebaseNow();
136
 
1 www 137
                $currentUserPlugin = $this->plugin('currentUserPlugin');
138
                $currentUser = $currentUserPlugin->getUser();
139
 
140
                $dataPost = (array) $form->getData();
141
 
142
                $comment = new Comment();
143
                $comment->comment = $dataPost['comment'];
144
                $comment->user_id = $currentUser->id;
145
                $comment->feed_id = $feed->id;
146
 
147
                $commentMapper = CommentMapper::getInstance($this->adapter);
148
                if($commentMapper->insert($comment)) {
149
 
150
 
151
                    if($feed->type == Feed::TYPE_UPDATE) {
152
                        $userMapper = UserMapper::getInstance($this->adapter);
153
                        $ownerFeed = $userMapper->fetchOne($feed->user_id);
154
 
155
                        $notification = new Notification();
156
                        $notification->type = Notification::TYPE_COMMENT_MY_FEED;
157
                        $notification->feed_id = $feed->id;
158
                        $notification->read     = Notification::NO;
159
                        $notification->user_id  = $ownerFeed->id;
160
                        $notification->message  = 'LABEL_COMMENT_MY_FEED';
161
                        $notification->url      = $this->url()->fromRoute('dashboard',['feed' => $feed->uuid]);
162
 
163
                        $notificationMapper = NotificationMapper::getInstance($this->adapter);
164
                        $notificationMapper->insert($notification);
165
 
166
                        $userNotificationMapper = UserNotificationSettingMapper::getInstance($this->adapter);
167
                        $userNotification = $userNotificationMapper->fetchOne($ownerFeed->id);
168
 
169
                        if($userNotification && $userNotification->comment_my_feed)
170
                        {
171
                            $emailTemplateMapper = EmailTemplateMapper::getInstance($this->adapter);
172
                            $emailTemplate = $emailTemplateMapper->fetchOne(EmailTemplate::ID_COMMENT_MY_FEED);
173
 
174
                            if($emailTemplate) {
175
                                $arrayCont = [
176
                                    'firstname'             => $currentUser->first_name,
177
                                    'lastname'              => $currentUser->last_name,
178
                                    'other_user_firstname'  => $ownerFeed->first_name,
179
                                    'other_user_lastname'   => $ownerFeed->last_name,
180
                                    'company_name'          => '',
181
                                    'group_name'            => '',
182
                                    'content'               => '',
183
                                    'code'                  => '',
184
                                    'link'                  => $this->url()->fromRoute('dashboard',['feed' => $feed->uuid], ['force_canonical' => true])
185
                                ];
186
 
187
                                $email = new QueueEmail($this->adapter);
188
                                $email->processEmailTemplate($emailTemplate, $arrayCont, $ownerFeed->email, trim($ownerFeed->first_name . ' ' . $ownerFeed->last_name));
189
                            }
190
                        }
191
                    }
192
 
193
                    $total_comments = $commentMapper->fetchCountCommentByFeedId($comment->feed_id);
194
 
195
                    $feed->total_comments = $total_comments;
196
                    $feedMapper->update($feed);
197
 
198
                    $response = [
199
                        'success'   => true,
3138 efrain 200
                        'data'   => $this->renderComment($comment->id, $now),
1 www 201
                        'total_comments' => $total_comments
202
                    ];
203
 
204
                    return new JsonModel($response);
205
 
206
                } else {
207
 
208
                    $response = [
209
                        'success'   => false,
210
                        'data'   => $commentMapper->getError()
211
                    ];
212
 
213
                    return new JsonModel($response);
214
                }
215
 
216
            } else {
217
                $message = '';;
218
                $form_messages = (array) $form->getMessages();
219
                foreach($form_messages  as $fieldname => $field_messages)
220
                {
221
                    foreach( $field_messages as $key => $value)
222
                    {
223
                        $message = $value;
224
                    }
225
                }
226
 
227
                $response = [
228
                    'success'   => false,
229
                    'data'   => $message
230
                ];
231
 
232
                return new JsonModel($response);
233
            }
234
 
235
 
236
        } else {
237
            $response = [
238
                'success' => false,
239
                'data' => 'ERROR_METHOD_NOT_ALLOWED'
240
            ];
241
 
242
            return new JsonModel($response);
243
        }
244
 
245
 
246
    }
247
 
248
    public function shareAction()
249
    {
250
        $id = $this->params()->fromRoute('id');
251
 
252
        $request = $this->getRequest();
253
        if($request->isPost()) {
254
            $feedMapper = FeedMapper::getInstance($this->adapter);
255
            $feed = $feedMapper->fetchOneByUuid($id);
256
            if(!$feed) {
257
                $response = [
258
                    'success' => false,
259
                    'data' => 'ERROR_POST_NOT_FOUND'
260
                ];
261
                return new JsonModel($response);
262
            }
263
 
264
            $dataPost = array_merge($request->getPost()->toArray(), $request->getFiles()->toArray());
265
            $dataPost['company_id'] = $this->params()->fromRoute('company_id');
266
            $dataPost['group_id'] = $this->params()->fromRoute('group_id');
267
            $dataPost['shared_feed_id'] = $feed->id;
268
 
269
 
270
 
271
 
272
            $response = $this->postOrShareFeed($dataPost);
273
            if( $response ['success']) {
274
                $feedMapper->incTotalShared($feed->id);
275
                $total_shared = $feedMapper->fetchTotalShared($feed->id);
276
 
277
                $response['total_shared'] = $total_shared;
278
            }
279
 
280
 
281
            return new JsonModel($response);
282
 
283
        } else {
284
            $response = [
285
                'success' => false,
286
                'data' => 'ERROR_METHOD_NOT_ALLOWED'
287
            ];
288
        }
289
 
290
        return new JsonModel($response);
291
    }
292
 
293
    public function commentDeleteAction()
294
    {
295
        $request = $this->getRequest();
296
        if($request->isPost()) {
297
            $currentUserPlugin = $this->plugin('currentUserPlugin');
298
            $currentUser = $currentUserPlugin->getUser();
299
 
300
            $feed_id = $this->params()->fromRoute('id');
301
            $comment = $this->params()->fromRoute('comment');
302
 
303
            $feedMapper = FeedMapper::getInstance($this->adapter);
304
            $feed = $feedMapper->fetchOneByUuid($feed_id);
305
 
306
            if($feed) {
307
 
308
                $commentMapper = CommentMapper::getInstance($this->adapter);
309
                $comment = $commentMapper->fetchOneByUuid($comment);
310
 
311
                if($comment && $comment->feed_id == $feed->id && $comment->user_id == $currentUser->id) {
312
 
313
                    $comment->status = Comment::STATUS_DELETED;
314
 
315
                    if($commentMapper->update($comment)) {
316
 
317
                        $total_comments = $commentMapper->fetchCountCommentByFeedId($comment->feed_id);
318
 
319
 
320
                        $feedMapper = FeedMapper::getInstance($this->adapter);
321
                        $feed = $feedMapper->fetchOne($comment->feed_id);
322
                        $feed->total_comments = $total_comments;
323
                        $feedMapper->update($feed);
324
 
325
 
326
 
327
 
328
 
329
                        $response = [
330
                            'success' => true,
331
                            'data' => 'LABEL_COMMENT_WAS_DELETED',
332
                            'total_comments' => $total_comments
333
                        ];
334
 
335
                    } else {
336
                        $response = [
337
                            'success' => false,
338
                            'data' => $commentMapper->getError()
339
                        ];
340
                    }
341
 
342
                } else {
343
                    $response = [
344
                        'success' => false,
345
                        'data' => 'ERROR_COMMENT_NOT_FOUND'
346
                    ];
347
                }
348
            } else {
349
                $response = [
350
                    'success' => false,
351
                    'data' => 'ERROR_COMMENT_NOT_FOUND'
352
                ];
353
            }
354
        } else {
355
            $response = [
356
                'success' => false,
357
                'data' => 'ERROR_METHOD_NOT_ALLOWED'
358
            ];
359
        }
360
 
361
        return new JsonModel($response);
362
    }
363
 
364
    public function deleteAction()
365
    {
366
        $request = $this->getRequest();
367
        if($request->isPost()) {
368
            $currentUserPlugin = $this->plugin('currentUserPlugin');
369
            $currentUser = $currentUserPlugin->getUser();
370
 
371
            $feed_id =  $this->params()->fromRoute('id');
372
 
373
            $feedMapper = FeedMapper::getInstance($this->adapter);
374
            $feed = $feedMapper->fetchOneByUuid($feed_id);
375
 
376
            if($feed) {
377
 
378
                if($feed->user_id && $feed->user_id == $currentUser->id) {
379
 
380
                    return new JsonModel($this->deleteFeed($feed));
381
                } else if ($feed->group_id) {
382
 
383
                    $groupMapper = GroupMapper::getInstance($this->adapter);
384
                    $group = $groupMapper->fetchOne($feed->group_id);
385
                    if($group && $group->user_id == $currentUser->id) {
386
                        return new JsonModel($this->deleteFeed($feed));
387
                    }
388
 
389
                } else if ($feed->company_id) {
390
                    $companyUserMapper = CompanyUserMapper::getInstance($this->adapter);
391
                    $companyUser = $companyUserMapper->fetchOneByCompanyIdAndUserId($feed->company_id, $currentUser->id);
392
                    if($companyUser) {
393
                        if(in_array($companyUser->type, [CompanyUser::TYPE_OWNER, CompanyUser::TYPE_ADMINISTRATOR, CompanyUser::TYPE_MANAGER])) {
394
                            return new JsonModel($this->deleteFeed($feed));
395
                        }
396
                    }
397
                }
398
 
399
                $response = [
400
                    'success' => false,
401
                    'data' => ' ERROR_UNAUTHORIZED'
402
                ];
403
 
404
 
405
            } else {
406
                $response = [
407
                    'success' => false,
408
                    'data' => 'ERROR_FEED_NOT_FOUND'
409
                ];
410
            }
411
 
412
            return new JsonModel($response);
413
 
414
        } else {
415
            $response = [
416
                'success' => false,
417
                'data' => 'ERROR_METHOD_NOT_ALLOWED'
418
            ];
419
        }
420
 
421
        return new JsonModel($response);
422
    }
423
 
424
    public function addAction()
425
    {
426
        $request = $this->getRequest();
427
        if($request->isPost()) {
428
            $dataPost = array_merge($request->getPost()->toArray(), $request->getFiles()->toArray());
429
            $dataPost['company_id'] = $this->params()->fromRoute('company_id');
430
            $dataPost['group_id'] = $this->params()->fromRoute('group_id');
431
            $response = $this->postOrShareFeed($dataPost);
432
 
433
 
434
            return new JsonModel($response);
435
 
436
        } else {
437
            $response = [
438
                'success' => false,
439
                'data' => 'ERROR_METHOD_NOT_ALLOWED'
440
            ];
441
        }
442
 
443
        return new JsonModel($response);
444
    }
445
 
446
    public function postOrShareFeed($dataPost)
447
    {
3138 efrain 448
        $utilMapper = UtilMapper::getInstance($this->adapter);
449
        $now = $utilMapper->getDatebaseNow();
450
 
1 www 451
        $currentUserPlugin = $this->plugin('currentUserPlugin');
452
        $currentUser = $currentUserPlugin->getUser();
453
 
454
        $companyId  = empty($dataPost['company_id']) ? '' : $dataPost['company_id'];
455
        $groupId    = empty($dataPost['group_id']) ? '' : $dataPost['group_id'];
456
 
457
 
458
        if($groupId || $companyId) {
459
            $form = new  CreateGroupCompanyForm($this->adapter);
460
        } else {
461
            $form = new  CreateForm($this->adapter);
462
        }
463
        $form->setData($dataPost);
464
        if($form->isValid()) {
465
 
412 geraldo 466
 
467
 
1 www 468
 
469
            $hydrator = new ObjectPropertyHydrator();
470
            $feed = new Feed();
471
            $hydrator->hydrate($dataPost, $feed);
472
 
473
            $company = null;
474
            $group = null;
475
 
476
            if($companyId) {
477
                $companyMapper = CompanyMapper::getInstance($this->adapter);
478
                $company = $companyMapper->fetchOneByUuid($companyId);
479
 
480
 
481
                if(!$company) {
482
                    return [
483
                        'success'   => false,
484
                        'data'   => 'ERROR_COMPANY_NOT_FOUND'
485
                    ];
486
                }
487
 
488
                if($company->status != Company::STATUS_ACTIVE) {
489
                    return [
490
                        'success'   => false,
491
                        'data'   => 'ERROR_COMPANY_IS_NOT_ACTIVE'
492
                    ];
493
                }
494
 
495
                $companyUserMapper = CompanyUserMapper::getInstance($this->adapter);
496
                $companyUser = $companyUserMapper->fetchOneByCompanyIdAndUserId($company->id, $currentUser->id);
497
 
498
                //print_r($companyUser); exit;
499
 
500
 
501
                if(!$companyUser || $companyUser->status != CompanyUser::STATUS_ACCEPTED) {
502
                    return [
503
                        'success'   => false,
504
                        'data'   => 'ERROR_UNAUTHORIZED'
505
                    ];
506
                }
507
 
508
            }
509
 
510
            if($groupId) {
511
                $groupMapper = GroupMapper::getInstance($this->adapter);
512
                $group = $groupMapper->fetchOneByUuid($groupId);
513
 
514
                if(!$group) {
515
                    return [
516
                        'success'   => false,
517
                        'data'   => 'ERROR_GROUP_NOT_FOUND'
518
                    ];
519
                }
520
 
521
                if($group->status != Group::STATUS_ACTIVE) {
522
                    return [
523
                        'success'   => false,
524
                        'data'   => 'ERROR_GROUP_IS_NOT_ACTIVE'
525
                    ];
526
                }
527
 
528
                $groupMemberMapper = GroupMemberMapper::getInstance($this->adapter);
529
                $groupMember = $groupMemberMapper->fetchOneByGroupIdAndUserId($group->id, $currentUser->id);
530
                if(!$groupMember || !in_array($groupMember->status, [GroupMember::STATUS_ACCEPTED, GroupMember::STATUS_AUTO_JOIN])) {
531
                    return [
532
                        'success'   => false,
533
                        'data'   => 'ERROR_UNAUTHORIZED'
534
                    ];
535
                }
536
            }
537
 
538
            $feed->company_id   = $company ? $company->id : null;
539
            $feed->group_id     = $group ? $group->id : null;
540
            $feed->user_id      = $currentUser->id;
424 geraldo 541
 
413 geraldo 542
            if($companyId) {
543
                $feed->type = Feed::TYPE_COMPANY;
544
            } else if ($groupId) {
545
                $feed->type = Feed::TYPE_GROUP;
546
            } else {
547
                $feed->type = Feed::TYPE_UPDATE;
548
            }
549
 
550
            $posted_or_shared   = $dataPost['posted_or_shared'];
551
            if($posted_or_shared != Feed::POSTED && $posted_or_shared != Feed::SHARED) {
552
                return [
553
                    'success'   => false,
554
                    'data'      => 'ERROR_SUPPLY_VALID_SHARING_STATUS'
555
                ];
556
            }
557
            $feed->posted_or_shared = $posted_or_shared;
558
            $feedMapper = FeedMapper::getInstance($this->adapter);
424 geraldo 559
 
414 geraldo 560
            $shared_with = isset($dataPost['shared_with']) ? $dataPost['shared_with'] : Feed::SHARE_WITH_PUBLIC;
561
            if ($shared_with != Feed::SHARE_WITH_PUBLIC && $shared_with != Feed::SHARE_WITH_CONNECTIONS) {
562
                return [
563
                    'status' => false,
564
                    'error' => 'ERROR_SUPPLY_VALID_SHARING_WITH_TYPE',
565
                ];
566
            }
567
 
568
            $feed->shared_with = $shared_with;
569
            if(Feed::SHARED == $feed->posted_or_shared) {
570
                $shared_feed_id     = empty($dataPost['shared_feed_id']) ? 0 : $dataPost['shared_feed_id'];
571
 
572
 
573
                $sharedFeed = $feedMapper->fetchOne($shared_feed_id);
574
                if(!$sharedFeed) {
575
                    return [
576
                        'status' => false,
577
                        'error' => 'ERROR_POST_SHARE',
578
                    ];
579
 
580
                }
581
 
582
                $feed->shared_feed_id       = $sharedFeed->id;
583
                $feed->shared_company_id    = $sharedFeed->shared_company_id;
584
                $feed->shared_group_id      = $sharedFeed->shared_group_id;
585
                $feed->shared_job_id        = $sharedFeed->shared_job_id;
586
            } else {
587
                $sharedFeed = null;
588
            }
589
 
590
            $feed->status = Feed::STATUS_PUBLISHED;
591
            $feed->total_comments    = 0;
592
            $feed->total_shared     = 0;
593
 
1 www 594
 
414 geraldo 595
            $files = $this->getRequest()->getFiles()->toArray();
596
            $file_type = '';
424 geraldo 597
 
415 geraldo 598
            $encoding = $this->params()->fromRoute('encoding');
599
            if($encoding == 'base64') {
600
 
601
 
602
                $fileBase64Name = $this->params()->fromPost('file_base64_name');
603
                $fileBase64Content = $this->params()->fromPost('file_base64_content');
604
 
605
                if($fileBase64Name && $fileBase64Content) {
606
 
607
                    try {
608
                        $fileBase64Content = base64_decode($fileBase64Content);
609
                        if($fileBase64Content) {
610
                            $feed_filename      = $this->normalizeString($fileBase64Name);
611
                            $feed_tmp_filename = 'data' . DIRECTORY_SEPARATOR . 'tmp';
612
                            if(!file_exists($feed_tmp_filename)) {
613
                                mkdir($feed_tmp_filename, 0755, true);
614
                            }
615
 
616
 
617
 
618
                            $feed_tmp_filename = 'data' . DIRECTORY_SEPARATOR . 'tmp' . DIRECTORY_SEPARATOR . $feed_filename;
619
                            file_put_contents($feed_tmp_filename, $fileBase64Content);
620
 
621
 
622
 
623
                            $mime_type = mime_content_type($feed_tmp_filename);
624
                            //echo '$mime_type = '. $mime_type; exit;
625
 
626
 
627
                            if($mime_type == 'image/jpg' || $mime_type == 'image/jpeg' || $mime_type == 'image/png') {
628
                                $file_type = Feed::FILE_TYPE_IMAGE;
629
                            } else if($mime_type == 'video/webm' || $mime_type == 'video/mpeg' || $mime_type == 'video/mpg' || $mime_type == 'video/mp4') {
630
                                $file_type = Feed::FILE_TYPE_VIDEO;
631
                            } else if($mime_type == 'application/pdf') {
632
                                $file_type = Feed::FILE_TYPE_DOCUMENT;
633
                            }
634
 
635
                        }
636
                    } catch(\Exception $e) {
637
 
638
                    }
639
                }
640
 
641
            } else {
642
 
643
                if(isset($files['file']) && empty($files['file']['error'])) {
644
                    $feed_tmp_filename  = $files['file']['tmp_name'];
645
                    $feed_filename      = $this->normalizeString($files['file']['name']);
646
 
647
                    $mime_type = mime_content_type($feed_tmp_filename);
648
 
649
 
650
                    if($mime_type == 'image/jpg' || $mime_type == 'image/jpeg' || $mime_type == 'image/png') {
651
                        $file_type = Feed::FILE_TYPE_IMAGE;
652
                    } else if($mime_type == 'video/webm' || $mime_type == 'video/mpeg' || $mime_type == 'video/mpg' || $mime_type == 'video/mp4') {
653
                        $file_type = Feed::FILE_TYPE_VIDEO;
654
                    } else if($mime_type == 'application/pdf') {
655
                        $file_type = Feed::FILE_TYPE_DOCUMENT;
656
                    }
657
                }
658
            }
424 geraldo 659
 
660
 
416 geraldo 661
            $result = $feedMapper->insert($feed);
662
            if($result) {
424 geraldo 663
 
664
                if($sharedFeed && $sharedFeed->type == Feed::TYPE_UPDATE) {
665
 
666
 
667
                    $userMapper = UserMapper::getInstance($this->adapter);
668
                    $ownerFeed = $userMapper->fetchOne($sharedFeed->user_id);
669
 
670
                    $notification = new Notification();
671
                    $notification->type     = Notification::TYPE_SHARE_MY_FEED;
672
                    $notification->read     = Notification::NO;
673
                    $notification->user_id  = $ownerFeed->id;
674
                    $notification->feed_id = $feed->id;
675
                    $notification->message  = 'LABEL_SHARE_MY_FEED';
676
                    $notification->url      = $this->url()->fromRoute('dashboard',['feed' => $sharedFeed->uuid]);
677
 
678
                    $notificationMapper = NotificationMapper::getInstance($this->adapter);
679
                    $notificationMapper->insert($notification);
680
 
681
                    $userNotificationMapper = UserNotificationSettingMapper::getInstance($this->adapter);
682
                    $userNotification = $userNotificationMapper->fetchOne($ownerFeed->id);
683
 
684
                    if($userNotification && $userNotification->share_my_feed)
685
                    {
686
                        $emailTemplateMapper = EmailTemplateMapper::getInstance($this->adapter);
687
                        $emailTemplate = $emailTemplateMapper->fetchOne(EmailTemplate::ID_SHARE_MY_FEED);
688
 
689
                        if($emailTemplate) {
690
                            $arrayCont = [
691
                                'firstname'             => $currentUser->first_name,
692
                                'lastname'              => $currentUser->last_name,
693
                                'other_user_firstname'  => $ownerFeed->first_name,
694
                                'other_user_lastname'   => $ownerFeed->last_name,
695
                                'company_name'          => '',
696
                                'group_name'            => '',
697
                                'content'               => '',
698
                                'code'                  => '',
699
                                'link'                  => $this->url()->fromRoute('dashboard',['feed' => $feed->uuid], ['force_canonical' => true])
700
                            ];
701
 
702
                            $email = new QueueEmail($this->adapter);
703
                            $email->processEmailTemplate($emailTemplate, $arrayCont, $ownerFeed->email, trim($ownerFeed->first_name . ' ' . $ownerFeed->last_name));
704
                        }
705
                    }
706
                }
707
 
708
 
709
                $feed = $feedMapper->fetchOne($feed->id);
430 geraldo 710
 
424 geraldo 711
                if( $file_type == Feed::FILE_TYPE_DOCUMENT) {
712
                    try {
713
                        $target_path = $this->config['leaderslinked.fullpath.feed'] . $feed->uuid;
714
                        if(!file_exists($target_path)) {
715
                            mkdir($target_path, 0755);
716
                        }
717
 
718
                        $full_filename = $target_path  . DIRECTORY_SEPARATOR .$feed_filename;
719
 
720
                        if($encoding == 'base64') {
721
                            $resultMoveOrRename = rename($feed_tmp_filename , $full_filename);
722
                        } else {
723
                            $resultMoveOrRename = move_uploaded_file($feed_tmp_filename , $full_filename);
724
                        }
725
 
726
                        if($resultMoveOrRename) {
727
 
728
                            $feed->file_type = $file_type;
729
                            $feed->file_name = basename($feed_filename);
730
                            $feedMapper->update($feed);
731
                        } else {
732
                            error_log('no se pudo mover o renombrar el documento : ' . $feed_tmp_filename . ' al directorio : ' . $full_filename );
733
                        }
734
                    } catch(\Throwable $e) {
735
                        error_log($e->getTraceAsString());
736
                    }
737
                }
738
                if( $file_type == Feed::FILE_TYPE_IMAGE) {
739
                    try {
740
                        $target_path = $this->config['leaderslinked.fullpath.feed'] . $feed->uuid;
741
                        if(!file_exists($target_path)) {
742
                            mkdir($target_path, 0755);
743
                        }
744
 
745
                        list($target_width, $target_height) = explode('x', $this->config['leaderslinked.image_sizes.feed_image_size']);
746
 
747
                        $feed_filename = substr($feed_filename, 0, strrpos($feed_filename, '.'))  . '.png';
748
                        $crop_to_dimensions = false;
749
                        if(Image::uploadImage($feed_tmp_filename, $target_path, $feed_filename, $target_width, $target_height, $crop_to_dimensions )) {
750
                            $feed->file_type = $file_type;
751
                            $feed->file_name = basename($feed_filename);
752
                            $feedMapper->update($feed);
753
                        }
754
                    } catch(\Throwable $e) {
755
                        error_log($e->getTraceAsString());
756
                    }
757
                }
758
                if( $file_type == Feed::FILE_TYPE_VIDEO) {
759
                    try {
760
                        $target_path = $this->config['leaderslinked.fullpath.feed'] . $feed->uuid;
761
                        if(!file_exists($target_path)) {
762
                            mkdir($target_path, 0755);
763
                        }
764
 
765
                        $full_filename = $target_path  . DIRECTORY_SEPARATOR . $feed_filename;
766
 
767
                        if($encoding == 'base64') {
768
                            $resultMoveOrRename = rename($feed_tmp_filename , $full_filename);
769
                        } else {
770
                            $resultMoveOrRename = move_uploaded_file($feed_tmp_filename , $full_filename);
771
                        }
772
 
773
                        if($resultMoveOrRename) {
774
 
775
                            $size = $this->config['leaderslinked.image_sizes.feed_image_size'];
776
                           // $getFromSecound = 2;
777
 
778
                            //extracción del cover
779
                            $generateFileName = substr($feed_filename, 0, strrpos($feed_filename, '.'));
780
                            $generateFile =  $target_path  . DIRECTORY_SEPARATOR . $generateFileName .  '.png';
781
                           // $cmd            = "/usr/bin/ffmpeg -i $full_filename -an -ss $getFromSecound -s $size $generateFile";
782
                            $cmd            = "/usr/bin/ffmpeg -i $full_filename -frames:v 1 -s $size $generateFile";
783
 
784
 
785
                            exec($cmd);
786
 
787
 
788
                            $feed->file_type = $file_type;
789
                            $feed->file_name = basename($feed_filename);
790
                            $feed->file_image_preview = basename($generateFile);
791
                            $feedMapper->update($feed);
792
 
793
                            $videoConvert = new VideoConvert();
794
                            $videoConvert->filename = $full_filename;
795
                            $videoConvert->type = VideoConvert::TYPE_FEED;
796
 
797
                            $videoConvertMapper = VideoConvertMapper::getInstance($this->adapter);
798
                            $videoConvertMapper->insert($videoConvert);
799
                        } else {
800
                            error_log('no se pudo mover o renombrar el documento : ' . $feed_tmp_filename . ' al directorio : ' . $full_filename );
801
                        }
802
                    } catch(\Throwable $e) {
803
                        error_log($e->getTraceAsString());
804
                    }
805
                }
806
 
807
 
808
                return [
809
                    'success'   => true,
3138 efrain 810
                    'data'   => $this->renderFeed($feed->id, $now)
424 geraldo 811
                ];
812
           } else {
813
                return [
814
                    'success'   => false,
815
                    'data'   => $feedMapper->getError()
816
                ];
817
           }
818
        } else {
819
            $messages = [];
820
            $form_messages = (array) $form->getMessages();
821
            foreach($form_messages  as $fieldname => $field_messages)
822
            {
823
                $messages[$fieldname] = array_values($field_messages);
824
            }
825
 
1 www 826
            return [
827
                'success'   => false,
424 geraldo 828
               'data'   => $messages
1 www 829
            ];
830
        }
831
    }
832
 
833
    public function likeAction()
834
    {
835
        $id = $this->params()->fromRoute('id');
836
 
837
        $request = $this->getRequest();
838
        if($request->isPost()) {
839
            $currentUserPlugin = $this->plugin('currentUserPlugin');
840
            $currentUser = $currentUserPlugin->getUser();
841
 
842
            $feedMapper = FeedMapper::getInstance($this->adapter);
843
            $feed = $feedMapper->fetchOneByUuid($id);
844
            if(!$feed) {
845
                $response = [
846
                    'success' => false,
847
                    'data' => 'ERROR_POST_NOT_FOUND'
848
                ];
849
                return new JsonModel($response);
850
            }
851
 
852
            $likeMapper = LikeMapper::getInstance($this->adapter);
853
            $like = $likeMapper->fetchOneByFeedIdAndUserId($feed->id, $currentUser->id);
854
 
855
            if($like) {
856
                $response = [
857
                    'success' => false,
858
                    'data' => 'ERROR_DUPLICATE_ACTION'
859
                ];
860
                return new JsonModel($response);
861
            }
862
 
863
            $like = new Like();
864
            $like->user_id = $currentUser->id;
865
            $like->feed_id = $feed->id;
866
 
867
            if($likeMapper->insert($like))
868
            {
1042 efrain 869
 
870
                $likes = $likeMapper->fetchCountLikeByFeedId($feed->id);
871
 
872
 
873
 
1 www 874
                if($feed->type == Feed::TYPE_UPDATE) {
875
 
876
 
877
                    $userMapper = UserMapper::getInstance($this->adapter);
878
                    $ownerFeed = $userMapper->fetchOne($feed->user_id);
879
 
880
                    $notification = new Notification();
881
                    $notification->type     = Notification::TYPE_LIKE_MY_FEED;
882
                    $notification->read     = Notification::NO;
1042 efrain 883
                    $notification->user_id  = $feed->user_id;
884
                    $notification->feed_id  = $feed->id;
1 www 885
                    $notification->message  = 'LABEL_LIKE_MY_FEED';
886
                    $notification->url      = $this->url()->fromRoute('dashboard',['feed' => $feed->uuid]);
887
 
888
                    $notificationMapper = NotificationMapper::getInstance($this->adapter);
889
                    $notificationMapper->insert($notification);
890
 
891
                    $userNotificationMapper = UserNotificationSettingMapper::getInstance($this->adapter);
892
                    $userNotification = $userNotificationMapper->fetchOne($ownerFeed->id);
893
 
894
                    if($userNotification && $userNotification->like_my_feed)
895
                    {
896
                        $emailTemplateMapper = EmailTemplateMapper::getInstance($this->adapter);
897
                        $emailTemplate = $emailTemplateMapper->fetchOne(EmailTemplate::ID_LIKE_MY_FEED);
898
 
899
                        if($emailTemplate) {
900
                            $arrayCont = [
901
                                'firstname'             => $currentUser->first_name,
902
                                'lastname'              => $currentUser->last_name,
903
                                'other_user_firstname'  => $ownerFeed->first_name,
904
                                'other_user_lastname'   => $ownerFeed->last_name,
905
                                'company_name'          => '',
906
                                'group_name'            => '',
907
                                'content'               => '',
908
                                'code'                  => '',
909
                                'link'                  => $this->url()->fromRoute('dashboard',['feed' => $feed->uuid], ['force_canonical' => true])
910
                            ];
911
 
912
                            $email = new QueueEmail($this->adapter);
913
                            $email->processEmailTemplate($emailTemplate, $arrayCont, $ownerFeed->email, trim($ownerFeed->first_name . ' ' . $ownerFeed->last_name));
914
                        }
915
                    }
916
 
917
                }
918
 
919
 
920
 
921
 
922
 
923
 
924
 
925
 
926
                $response = [
1042 efrain 927
                    'success' => true,
928
                    'data' => [
929
                        'likes' => $likes
930
                    ]
1 www 931
                ];
932
            } else {
933
                $response = [
934
                    'success' => false,
935
                    'data' => $likeMapper->getError()
936
                ];
937
            }
938
            return new JsonModel($response);
939
 
940
        }
941
 
942
        $response = [
943
            'success' => false,
944
            'data' => 'ERROR_METHOD_NOT_ALLOWED'
945
        ];
946
        return new JsonModel($response);
947
    }
948
 
949
    public function unlikeAction()
950
    {
951
        $id = $this->params()->fromRoute('id');
952
 
953
        $request = $this->getRequest();
954
        if($request->isPost()) {
955
            $currentUserPlugin = $this->plugin('currentUserPlugin');
956
            $currentUser = $currentUserPlugin->getUser();
957
 
958
            $feedMapper = FeedMapper::getInstance($this->adapter);
959
            $feed = $feedMapper->fetchOneByUuid($id);
960
            if(!$feed) {
961
                $response = [
962
                    'success' => false,
963
                    'data' => 'ERROR_POST_NOT_FOUND'
964
                ];
965
                return new JsonModel($response);
966
            }
967
 
968
            $likeMapper = LikeMapper::getInstance($this->adapter);
969
            $like = $likeMapper->fetchOneByFeedIdAndUserId($feed->id, $currentUser->id);
970
 
971
            if(!$like) {
972
                $response = [
973
                    'success' => false,
974
                    'data' => 'ERROR_DUPLICATE_ACTION'
975
                ];
976
                return new JsonModel($response);
977
            }
978
 
979
            if($likeMapper->deleteByFeedIdAndUserId($feed->id, $currentUser->id))
980
            {
1042 efrain 981
                $likes = $likeMapper->fetchCountLikeByFeedId($feed->id);
982
 
983
 
1 www 984
                $response = [
1042 efrain 985
                    'success' => true,
986
                    'data' => [
987
                        'likes' => $likes
988
                    ]
1 www 989
                ];
990
            } else {
991
                $response = [
992
                    'success' => false,
993
                    'data' => $likeMapper->getError()
994
                ];
995
            }
996
            return new JsonModel($response);
997
 
998
        }
999
 
1000
        $response = [
1001
            'success' => false,
1002
            'data' => 'ERROR_METHOD_NOT_ALLOWED'
1003
        ];
1004
        return new JsonModel($response);
1005
    }
1006
 
1007
    public function timelineAction()
1008
    {
3138 efrain 1009
        $utilMapper = UtilMapper::getInstance($this->adapter);
1010
        $now = $utilMapper->getDatebaseNow();
1011
 
1 www 1012
        $currentUserPlugin = $this->plugin('currentUserPlugin');
1013
        $currentUser = $currentUserPlugin->getUser();
1014
 
1015
 
1016
        $type   = $this->params()->fromRoute('type');
3139 efrain 1017
 
1018
 
1 www 1019
        if($type == 'user') {
1020
            $id = $currentUser->id;
1021
        } else {
1022
            $id     = $this->params()->fromRoute('id');
1023
        }
1024
 
1025
 
1026
 
1027
        $request = $this->getRequest();
1028
        if($request->isGet()) {
1029
 
1030
            $page = (int) $this->params()->fromQuery('page');
1031
            if($type == 'user') {
1032
                $connectionMapper = ConnectionMapper::getInstance($this->adapter);
1033
                $records = $connectionMapper->fetchAllConnectionsByUser($id);
1034
 
1035
                $connectionIds = [0];
1036
                foreach($records as $record)
1037
                {
1038
                    if($currentUser->id == $record->request_from) {
1039
                        array_push($connectionIds, $record->request_to);
1040
                    } else {
1041
                        array_push($connectionIds, $record->request_from);
1042
                    }
1043
                }
1044
                array_push($connectionIds, 1);
1045
 
1046
                $companyFollowerMapper = CompanyFollowerMapper::getInstance($this->adapter);
1047
                $records = $companyFollowerMapper->fetchAllByFollowerId($currentUser->id);
1048
 
1049
                $companyIds = [0];
1050
                foreach($records as $record)
1051
                {
1052
                    if(!in_array($record->company_id, $companyIds)) {
1053
                        array_push($companyIds, $record->company_id);
1054
                    }
1055
                }
1056
 
1057
                $companyUserMapper = CompanyUserMapper::getInstance($this->adapter);
1058
                $companyUsers = $companyUserMapper->fetchAllByUserId($currentUser->id);
1059
 
1060
                foreach($companyUsers as $companyUser)
1061
                {
1062
                    if($companyUser->status == CompanyUser::STATUS_ACCEPTED) {
1063
                        if(!in_array($companyUser->company_id, $companyIds)) {
1064
                            array_push($companyIds, $companyUser->company_id);
1065
                        }
1066
                    }
1067
                }
1068
 
1069
 
1070
                $queryMapper = QueryMapper::getInstance($this->adapter);
1071
                $select = $queryMapper->getSql()->select(FeedMapper::_TABLE);
1072
                $select->columns(['id']);
1073
                $select->where->equalTo('status', Feed::STATUS_PUBLISHED)
1074
                    ->AND->NEST
1075
                    ->OR->NEST->equalTo('user_id',$id)->and->equalTo('type', Feed::TYPE_UPDATE)->UNNEST
1076
                    ->OR->NEST->and->equalTo('type', Feed::TYPE_UPDATE)->and->equalTo('shared_with', Feed::SHARE_WITH_PUBLIC)->UNNEST
1077
                    ->OR->NEST->in('user_id', $connectionIds)->and->equalTo('type', Feed::TYPE_UPDATE)->and->equalTo('shared_with', Feed::SHARE_WITH_CONNECTIONS)->UNNEST
1078
                    ->OR->NEST->or->in('company_id', $companyIds)->and->equalTo('type', Feed::TYPE_COMPANY)->UNNEST
1079
                    ->UNNEST;
1080
                $select->order('added_on desc');
1081
 
1082
 
1083
            }
1084
            if($type == 'company') {
1085
                $companyMapper = CompanyMapper::getInstance($this->adapter);
1086
                $company = $companyMapper->fetchOneByUuid($id);
1087
 
1088
                if(!$company || $company->status != Company::STATUS_ACTIVE) {
1089
                    $id = 0;
1090
                } else {
1091
                    $companyFollowerMapper = CompanyFollowerMapper::getInstance($this->adapter);
1092
                    $companyFollower = $companyFollowerMapper->fetchOneByCompanyIdAndUserId($company->id, $currentUser->id);
1093
                    if($companyFollower) {
1094
                        $id = $company->id;
1095
                    } else {
1096
 
1097
                        $companyUserMapper = CompanyUserMapper::getInstance($this->adapter);
1098
                        $companyUser = $companyUserMapper->fetchOneByCompanyIdAndUserId($company->id, $currentUser->id);
1099
 
1100
                        if(!$companyUser || $companyUser->status != CompanyUser::STATUS_ACCEPTED) {
1101
                            $id = 0;
1102
                        } else {
1103
                            $id = $company->id;
1104
                        }
1105
 
1106
                    }
1107
 
1108
                }
1109
 
1110
 
1111
                $queryMapper = QueryMapper::getInstance($this->adapter);
1112
                $select = $queryMapper->getSql()->select(FeedMapper::_TABLE);
1113
                $select->columns(['id']);
1114
                $select->where->equalTo('status', Feed::STATUS_PUBLISHED);
1115
                $select->where->equalTo('company_id',$id);
1116
                $select->where->and->equalTo('type', Feed::TYPE_COMPANY);
1117
                $select->order('added_on desc');
1118
            }
1119
            if($type == 'group') {
1120
                $groupMapper = GroupMapper::getInstance($this->adapter);
1121
                $group = $groupMapper->fetchOneByUuid($id);
3139 efrain 1122
 
1123
                $id = 0;
1124
 
1125
                if($group || $group->status == Group::STATUS_ACTIVE) {
1 www 1126
                    $groupMemberMapper = GroupMemberMapper::getInstance($this->adapter);
1127
                    $groupMember = $groupMemberMapper->fetchOneByGroupIdAndUserId($group->id, $currentUser->id);
1128
                    if($groupMember) {
3139 efrain 1129
 
1 www 1130
 
3139 efrain 1131
                        if($groupMember->status == GroupMember::STATUS_ACCEPTED ||
1132
                            $groupMember->status == GroupMember::STATUS_AUTO_JOIN ) {
1133
 
1134
                            $id =  $groupMember->group_id;
1135
                        }
1136
 
1 www 1137
                    }
1138
                }
1139
 
1140
                $queryMapper = QueryMapper::getInstance($this->adapter);
1141
                $select = $queryMapper->getSql()->select(FeedMapper::_TABLE);
1142
                $select->columns(['id']);
1143
                $select->where->equalTo('status', Feed::STATUS_PUBLISHED);
3139 efrain 1144
                $select->where->equalTo('group_id', $id);
1 www 1145
                $select->where->and->equalTo('type', Feed::TYPE_GROUP);
1146
                $select->order('added_on desc');
3139 efrain 1147
 
1 www 1148
            }
1149
 
1150
            $dbSelect = new DbSelect($select, $this->adapter);
1151
            $paginator = new Paginator($dbSelect);
1152
            $paginator->setCurrentPageNumber($page ? $page : 1);
1153
            $paginator->setItemCountPerPage(10);
1154
 
1155
            $items = [];
1156
            $feeds = $paginator->getCurrentItems();
1157
            foreach($feeds as $feed)
1158
            {
3138 efrain 1159
                $items[] = $this->renderFeed($feed->id, $now);
1 www 1160
            }
1161
 
1162
            $response = [
1163
                'success' => true,
1164
                'data' => [
1165
                    'total' => [
1166
                        'count' => $paginator->getTotalItemCount(),
1167
                        'pages' => $paginator->getPages()->pageCount,
1168
                    ],
1169
                    'current' => [
1170
                        'items'    => $items,
1171
                        'page'     => $paginator->getCurrentPageNumber(),
1172
                        'count'    => $paginator->getCurrentItemCount(),
1173
                    ]
1174
                ]
1175
            ];
1176
 
1177
            return new JsonModel($response);
1178
        }
1179
 
1180
        $response = [
1181
            'success' => false,
1182
            'data' => 'ERROR_METHOD_NOT_ALLOWED'
1183
        ];
1184
 
1185
 
1186
        return new JsonModel($response);
1187
    }
1188
 
1189
    /**
1190
     *
1191
     * @param string $str
1192
     * @return string
1193
     */
1194
    private function normalizeString ($str = '')
1195
    {
1196
        $basename  = substr($str, 0, strrpos($str, '.'));
1197
        $basename  = str_replace('.', '-', $basename);
1198
 
1199
        $extension  = substr($str, strrpos($str, '.'));
1200
 
1201
        $str = $basename . $extension;
1202
 
1203
        $str = strip_tags($str);
1204
        $str = preg_replace('/[\r\n\t ]+/', ' ', $str);
1205
        $str = preg_replace('/[\"\*\/\:\<\>\?\'\|\,]+/', ' ', $str);
1206
        $str = strtolower($str);
1207
        $str = html_entity_decode( $str, ENT_QUOTES, "utf-8" );
1208
        $str = htmlentities($str, ENT_QUOTES, "utf-8");
1209
        $str = preg_replace("/(&)([a-z])([a-z]+;)/i", '$2', $str);
1210
        $str = str_replace(' ', '-', $str);
1211
        $str = rawurlencode($str);
1212
        $str = str_replace('%', '-', $str);
1213
        return trim(strtolower($str));
1214
    }
1215
 
1216
 
1217
 
1218
    /**
1219
     *
1220
     * @param int $feed_id
1221
     * @return array
1222
     */
3138 efrain 1223
    private function renderFeed($feed_id, $now)
1 www 1224
    {
1225
        $currentUserPlugin = $this->plugin('currentUserPlugin');
1226
        $currentUser = $currentUserPlugin->getUser();
1227
 
1228
        $acl = $this->getEvent()->getViewModel()->getVariable('acl');
1229
 
1230
        $userMapper = UserMapper::getInstance($this->adapter);
1231
        $feedMapper = FeedMapper::getInstance($this->adapter);
1232
        $feed = $feedMapper->fetchOne($feed_id);
1233
 
1234
 
1235
        $likeMapper = LikeMapper::getInstance($this->adapter);
1236
        $like = $likeMapper->fetchOneByFeedIdAndUserId($feed->id, $currentUser->id);
1042 efrain 1237
        $likes = $likeMapper->fetchCountLikeByFeedId($feed->id);
1 www 1238
 
1239
        $params = [
1240
            'id' => $feed->uuid
1241
        ];
1242
        if($feed->company_id) {
1243
            $companyMapper = CompanyMapper::getInstance($this->adapter);
1244
            $company = $companyMapper->fetchOne($feed->company_id);
1245
 
1246
            $params['company_id'] = $company->uuid;
1247
        } else {
1248
            $company = null;
1249
        }
1250
        if($feed->group_id) {
1251
            $groupMapper = GroupMapper::getInstance($this->adapter);
1252
            $group = $groupMapper->fetchOne($feed->group_id);
1253
 
1254
            $params['group_id'] = $group->uuid;
1255
        } else {
1256
            $group = null;
1257
        }
1258
 
1259
        $item = [
1260
            'feed_unique' => uniqid(),
1261
            'feed_uuid' => $feed->uuid,
1262
            'feed_is_liked' => $like ? true : false,
1263
            'feed_like_url' => $this->url()->fromRoute('feed/like',  $params),
1264
            'feed_unlike_url' => $this->url()->fromRoute('feed/unlike',  $params),
1265
            'feed_share_url' => $this->url()->fromRoute('feed/share',  $params),
1266
            'feed_delete_url' =>  '',
1267
            'feed_content_type' => $feed->file_type ? $feed->file_type : '',
1042 efrain 1268
            'feed_likes' =>  $likes,
1 www 1269
        ];
1270
 
1271
        if($feed->posted_or_shared == Feed::POSTED) {
1272
 
1273
 
1274
            if($feed->type == Feed::TYPE_COMPANY)
1275
            {
1276
                $companyMapper = CompanyMapper::getInstance($this->adapter);
1277
                $company = $companyMapper->fetchOne($feed->company_id);
1278
                $item['owner_url'] = $this->url()->fromRoute('company/view', ['id' => $company->uuid]);
1279
                $item['owner_image'] = $this->url()->fromRoute('storage', ['code' => $company->uuid, 'type' => 'company', 'filename' => $company->image]);
1280
                $item['owner_name'] = $company->name;
1281
                /*
1282
 
1283
                $companyUserMapper = CompanyUserMapper::getInstance($this->adapter);
1284
                $companyUser = $companyUserMapper->fetchOneByCompanyIdAndUserId($company->id, $currentUser->id);
1285
 
1286
 
1287
                if( $companyUser && $acl->isAllowed( $currentUser->usertype_id, 'my-company/feed' ) ) {
1288
                    $item['feed_delete_url'] = $this->url()->fromRoute('feed/delete',  $params);
1289
                }
1290
                */
1291
 
1292
 
1293
            } else if($feed->type == Feed::TYPE_GROUP)
1294
            {
1295
                $groupMapper = GroupMapper::getInstance($this->adapter);
1296
                $group = $groupMapper->fetchOne($feed->group_id);
1297
                $item['owner_url'] = '';
1298
                $item['owner_image'] = $this->url()->fromRoute('storage', ['code' => $group->uuid, 'type' => 'group', 'filename' => $group->image]);
1299
                $item['owner_name'] = $group->name;
1300
 
1301
                if($group->user_id == $currentUser->id) {
1302
                    $item['feed_delete_url'] = $this->url()->fromRoute('feed/delete',  $params);
1303
                }
1304
            } else {
1305
                $userMapper = UserMapper::getInstance($this->adapter);
1306
                $user = $userMapper->fetchOne($feed->user_id);
1307
 
1308
                $item['owner_url'] = $this->url()->fromRoute('profile/view', ['id' => $user->uuid]);
1309
                $item['owner_image'] = $this->url()->fromRoute('storage', ['code' => $user->uuid, 'type' => 'user', 'filename' => $user->image]);
1310
                $item['owner_name'] = $user->first_name . ' ' . $user->last_name;
1311
 
1312
                if($feed->user_id == $currentUser->id) {
1313
                    $item['feed_delete_url'] = $this->url()->fromRoute('feed/delete',  $params);
1314
                }
1315
 
1316
            }
1317
        } else {
1318
            if($feed->user_id == $currentUser->id) {
1319
                $item['feed_delete_url'] = $this->url()->fromRoute('feed/delete',  $params);
1320
            }
1321
        }
1322
 
1323
        $userMapper = UserMapper::getInstance($this->adapter);
1324
        $user = $userMapper->fetchOne($feed->user_id);
1325
 
1326
        if($feed->posted_or_shared == Feed::SHARED) {
1327
            $item['owner_url'] = $this->url()->fromRoute('profile/view', ['id' => $user->uuid]);
1328
            $item['owner_image'] = $this->url()->fromRoute('storage', ['code' => $user->uuid, 'type' => 'user', 'filename' => $user->image]);
1329
            $item['owner_name'] = $user->first_name . ' ' . $user->last_name;
1330
        }
1331
 
1332
        $item['owner_description'] = $feed->description;
1333
 
1334
        $item['owner_shared'] = $feed->total_shared;
1335
        $item['owner_comments'] = $feed->total_comments;
1336
 
1337
 
3138 efrain 1338
        $item['owner_time_elapse'] = Functions::timeAgo($feed->added_on, $now);
1 www 1339
 
1340
        if($feed->file_type == Feed::FILE_TYPE_IMAGE) {
1341
            $item['owner_file_image'] = $this->url()->fromRoute('storage', ['code' => $feed->uuid, 'type' => 'feed', 'filename' => $feed->file_name]);
1342
 
1343
        }
1344
        if($feed->file_type == Feed::FILE_TYPE_DOCUMENT) {
1345
            $item['owner_file_document'] = $this->url()->fromRoute('storage', ['code' => $feed->uuid, 'type' => 'feed', 'filename' => $feed->file_name]);
1346
        }
1347
        if($feed->file_type == Feed::FILE_TYPE_VIDEO) {
1348
            $item['owner_file_image_preview'] = $this->url()->fromRoute('storage', ['code' => $feed->uuid, 'type' => 'feed', 'filename' => $feed->file_image_preview]);
1349
            $item['owner_file_video'] = $this->url()->fromRoute('storage', ['code' => $feed->uuid, 'type' => 'feed', 'filename' => $feed->file_name]);
1350
        }
1351
 
1352
        if($feed->posted_or_shared == Feed::SHARED) {
1353
 
1354
 
3143 efrain 1355
            $sharedFeed = $feedMapper->fetchOneAnyStatus($feed->shared_feed_id);
1 www 1356
 
3143 efrain 1357
 
1358
 
1359
 
1 www 1360
            $item['shared_description'] = $sharedFeed->description;
3138 efrain 1361
            $item['shared_time_elapse'] = Functions::timeAgo( $sharedFeed->added_on, $now);
1 www 1362
 
1363
            if($sharedFeed->file_type == Feed::FILE_TYPE_IMAGE) {
1364
                $item['shared_file_image'] = $this->url()->fromRoute('storage', ['code' => $sharedFeed->uuid, 'type' => 'feed', 'filename' => $sharedFeed->file_name]);
1365
 
1366
            }
1367
            if($sharedFeed->file_type == Feed::FILE_TYPE_DOCUMENT) {
1368
                $item['shared_file_document'] = $this->url()->fromRoute('storage', ['code' => $sharedFeed->uuid, 'type' => 'feed', 'filename' => $sharedFeed->file_name]);
1369
            }
1370
            if($sharedFeed->file_type == Feed::FILE_TYPE_VIDEO) {
1371
                $item['shared_file_image_preview'] = $this->url()->fromRoute('storage', ['code' => $sharedFeed->uuid, 'type' => 'feed', 'filename' => $sharedFeed->file_image_preview]);
1372
                $item['shared_file_video'] = $this->url()->fromRoute('storage', ['code' => $sharedFeed->uuid, 'type' => 'feed', 'filename' => $sharedFeed->file_name]);
1373
            }
1374
 
1375
            $item['shared_content_type'] = $sharedFeed->file_type ? $sharedFeed->file_type : '';
1376
 
1377
            if($feed->company_id)
1378
            {
1379
 
1380
                $companyMapper = CompanyMapper::getInstance($this->adapter);
1381
                $sharedCompany = $companyMapper->fetchOne($feed->company_id);
1382
                $item['shared_url'] = $this->url()->fromRoute('company/view', ['id' => $sharedCompany->uuid]);
1383
                $item['shared_image'] = $this->url()->fromRoute('storage', ['code' => $sharedCompany->uuid, 'type' => 'company', 'filename' => $sharedCompany->image]);
1384
                $item['shared_name'] = $sharedCompany->name;
1385
            } else if($feed->group_id)
1386
            {
1387
                $groupMapper = GroupMapper::getInstance($this->adapter);
1388
                $sharedGroup = $groupMapper->fetchOne($feed->group_id);
1389
                $item['shared_url'] = '';
1390
                $item['shared_image'] = $this->url()->fromRoute('storage', ['code' => $sharedGroup->uuid, 'type' => 'group', 'filename' =>  $sharedGroup->image]);
1391
                $item['shared_name'] = $sharedGroup->name;
1392
            } else {
1393
 
1394
                $sharedUser = $userMapper->fetchOne($sharedFeed->user_id);
1395
                $item['shared_url'] = $this->url()->fromRoute('profile/view', ['id' => $sharedUser->uuid]);
1396
                $item['shared_image'] = $this->url()->fromRoute('storage', ['code' => $sharedUser->uuid, 'type' => 'user', 'filename' => $sharedUser->image]);
1397
                $item['shared_name'] = $sharedUser->first_name . ' ' . $sharedUser->last_name;
1398
            }
1399
 
1400
        }
1401
 
1402
        $commentMapper = CommentMapper::getInstance($this->adapter);
1403
        $records = $commentMapper->fetchAllPublishedByFeedId($feed->id);
1404
 
1405
        $comments = [];
1406
        foreach($records as $record)
1407
        {
1408
            $user = $userMapper->fetchOne($record->user_id);
3138 efrain 1409
 
1 www 1410
            if($record->user_id == $currentUser->id) {
1411
                $link_delete = $this->url()->fromRoute('feed/comment/delete',['id' => $feed->uuid, 'comment' => $record->uuid]);
1412
            } else {
1413
                $link_delete = '';
1414
            }
1415
 
1416
            array_push($comments, [
1417
                'unique' => uniqid(),
1418
                'user_url' => $this->url()->fromRoute('profile/view', ['id' => $user->uuid]),
1419
                'user_name' => $user->first_name . ' ' . $user->last_name,
1420
                'user_image' => $this->url()->fromRoute('storage', ['type' => 'user',  'code' => $user->uuid, 'filename' =>  $user->image ]),
3138 efrain 1421
                'time_elapsed' => Functions::timeAgo($record->added_on, $now),
1 www 1422
                'comment' => $record->comment,
1423
                'link_delete' => $link_delete
1424
            ]);
1425
        }
1426
        $item['comment_add_url'] = $this->url()->fromRoute('feed/comment', ['id' => $feed->uuid]);
1427
        $item['comments'] = $comments;
1428
 
1429
        return $item;
1430
    }
1431
 
1432
    /**
1433
     *
1434
     * @param int $comment_id
1435
     * @return array
1436
     */
3138 efrain 1437
    private function renderComment($comment_id, $now)
1 www 1438
    {
1439
        $item = [];
1440
 
1441
        $commentMapper = CommentMapper::getInstance($this->adapter);
1442
        $record = $commentMapper->fetchOne($comment_id);
1443
 
1444
        $feedMapper = FeedMapper::getInstance($this->adapter);
1445
        $feed = $feedMapper->fetchOne($record->feed_id);
1446
 
1447
        if($record) {
1448
            $userMapper = UserMapper::getInstance($this->adapter);
1449
 
1450
            $user = $userMapper->fetchOne($record->user_id);
1451
 
1452
            $item['unique'] = uniqid();
1453
            $item['user_image'] = $this->url()->fromRoute('storage', ['type' => 'user',  'code' => $user->uuid, 'filename' =>  $user->image ]);
1454
            $item['user_url'] = $this->url()->fromRoute('profile', ['id' => $user->uuid]);
1455
            $item['user_name'] = $user->first_name . ' ' . $user->last_name;
3138 efrain 1456
            $item['time_elapsed'] = Functions::timeAgo($record->added_on, $now);
1 www 1457
            $item['comment'] = $record->comment;
1458
            $item['link_delete'] = $this->url()->fromRoute('feed/comment/delete',['id' => $feed->uuid, 'comment' => $record->uuid ]);
1459
        }
1460
        return $item;
1461
    }
1462
 
1463
    /**
1464
     *
1465
     * @param string $path
1466
     * @return boolean
1467
     */
1468
    private function deletePath($path)
1469
    {
1470
        try {
1471
            if (is_dir($path)){
1472
                if ($dh = opendir($path)) {
1473
                    while (($file = readdir($dh)) !== false)
1474
                    {
1475
                        if($file == '.' || $file == '..') {
1476
                            continue;
1477
                        }
1478
                        unlink($path . DIRECTORY_SEPARATOR . $file);
1479
                    }
1480
                    closedir($dh);
1481
                }
1482
 
1483
                rmdir($path);
1484
            }
1485
            return true;
1486
        }
1487
        catch (\Throwable $e)
1488
        {
1489
            error_log($e->getTraceAsString());
1490
            return false;
1491
        }
1492
    }
1493
 
1494
 
1495
    /**
1496
     *
1497
     * @param Feed $feed
1498
     * @return array
1499
     */
1500
    private function deleteFeed($feed)
1501
    {
1502
        $feedMapper = FeedMapper::getInstance($this->adapter);
1503
        $feed->status = Feed::STATUS_DELETED;
1504
        if($feedMapper->update($feed)) {
1505
            $response = [
1506
                'success' => true,
1507
                'data' => 'LABEL_FEED_WAS_DELETED'
1508
            ];
1509
 
1510
        } else {
1511
            $response = [
1512
                'success' => false,
1513
                'data' => $feedMapper->getError()
1514
            ];
1515
        }
1516
 
1517
 
1518
        /*$commentMapper = CommentMapper::getInstance($this->adapter);
1519
        if($commentMapper->deleteAllByFeedId($feed->id)) {
1520
            if($feedMapper->delete($feed->id)) {
1521
                $target_path = $this->config['leaderslinked.fullpath.feed'] . DIRECTORY_SEPARATOR . $feed->id;
1522
                if(file_exists($target_path)) {
1523
                    $this->deletePath($target_path);
1524
                }
1525
 
1526
                $response = [
1527
                    'success' => true,
1528
                    'data' => 'LABEL_FEED_WAS_DELETED'
1529
                ];
1530
 
1531
            } else {
1532
                $response = [
1533
                    'success' => false,
1534
                    'data' => $feedMapper->getError()
1535
                ];
1536
            }
1537
        } else {
1538
            $response = [
1539
                'success' => false,
1540
                'data' => $commentMapper->getError()
1541
            ];
1542
 
1543
        }*/
1544
 
1545
        return $response;
1546
    }
1547
 
1548
 
1549
}