Proyectos de Subversion LeadersLinked - Services

Rev

Rev 334 | Rev 347 | Ir a la última revisión | | Comparar con el anterior | Ultima modificación | Ver Log |

Rev Autor Línea Nro. Línea
1 efrain 1
<?php
2
declare(strict_types=1);
3
 
4
namespace LeadersLinked\Controller;
5
 
6
use Laminas\Mvc\Controller\AbstractActionController;
7
use Laminas\View\Model\JsonModel;
8
use LeadersLinked\Library\Functions;
9
use LeadersLinked\Mapper\CompanyUserMapper;
10
use LeadersLinked\Form\Feed\CreateForm;
11
use LeadersLinked\Hydrator\ObjectPropertyHydrator;
12
use LeadersLinked\Model\Feed;
13
use LeadersLinked\Mapper\FeedMapper;
14
use LeadersLinked\Mapper\GroupMapper;
15
use LeadersLinked\Mapper\UserMapper;
16
use LeadersLinked\Mapper\CommentMapper;
17
use LeadersLinked\Mapper\ConnectionMapper;
18
use LeadersLinked\Mapper\CompanyFollowerMapper;
19
use LeadersLinked\Mapper\QueryMapper;
20
use Laminas\Paginator\Paginator;
21
use Laminas\Paginator\Adapter\DbSelect;
22
use LeadersLinked\Mapper\ContentReactionMapper;
23
use LeadersLinked\Model\ContentReaction;
24
use LeadersLinked\Form\Feed\CommentForm;
25
use LeadersLinked\Model\Comment;
26
use LeadersLinked\Form\Feed\CreateGroupCompanyForm;
27
use LeadersLinked\Model\CompanyUser;
28
use LeadersLinked\Model\FastSurvey;
29
use LeadersLinked\Mapper\CompanyMapper;
30
use LeadersLinked\Model\Company;
31
use LeadersLinked\Model\Group;
32
use LeadersLinked\Mapper\GroupMemberMapper;
33
use LeadersLinked\Model\GroupMember;
34
use LeadersLinked\Model\Notification;
35
use LeadersLinked\Mapper\NotificationMapper;
36
use LeadersLinked\Mapper\UserNotificationSettingMapper;
37
use LeadersLinked\Mapper\EmailTemplateMapper;
38
use LeadersLinked\Model\EmailTemplate;
39
use LeadersLinked\Library\QueueEmail;
40
use LeadersLinked\Mapper\FastSurveyMapper;
41
use LeadersLinked\Mapper\FastSurveyVoteMapper;
42
use LeadersLinked\Model\FastSurveyVote;
192 efrain 43
use LeadersLinked\Mapper\AbuseReportMapper;
44
use LeadersLinked\Mapper\UserBlockedMapper;
45
use LeadersLinked\Model\AbuseReport;
232 efrain 46
use LeadersLinked\Model\User;
283 www 47
use LeadersLinked\Library\Storage;
345 www 48
use LeadersLinked\Model\VideoConvert;
49
use LeadersLinked\Mapper\VideoConvertMapper;
1 efrain 50
 
51
 
52
class FeedController extends AbstractActionController
53
{
54
    /**
55
     *
56
     * @var \Laminas\Db\Adapter\AdapterInterface
57
     */
58
    private $adapter;
59
 
60
    /**
61
     *
62
     * @var \LeadersLinked\Cache\CacheInterface
63
     */
64
    private $cache;
65
 
66
 
67
    /**
68
     *
69
     * @var \Laminas\Log\LoggerInterface
70
     */
71
    private $logger;
72
 
73
    /**
74
     *
75
     * @var array
76
     */
77
    private $config;
78
 
79
 
80
    /**
81
     *
82
     * @var \Laminas\Mvc\I18n\Translator
83
     */
84
    private $translator;
85
 
345 www 86
 
1 efrain 87
 
289 www 88
 
1 efrain 89
    /**
90
     *
91
     * @param \Laminas\Db\Adapter\AdapterInterface $adapter
92
     * @param \LeadersLinked\Cache\CacheInterface $cache
93
     * @param \Laminas\Log\LoggerInterface LoggerInterface $logger
94
     * @param array $config
95
     * @param \Laminas\Mvc\I18n\Translator $translator
96
     */
97
    public function __construct($adapter, $cache, $logger, $config, $translator)
98
    {
99
        $this->adapter      = $adapter;
100
        $this->cache        = $cache;
101
        $this->logger       = $logger;
102
        $this->config       = $config;
103
        $this->translator   = $translator;
345 www 104
 
1 efrain 105
    }
106
 
107
    /**
108
     *
109
     * Generación del listado de perfiles
110
     * {@inheritDoc}
111
     * @see \Laminas\Mvc\Controller\AbstractActionController::indexAction()
112
     */
113
    public function indexAction()
114
    {
115
 
116
        return new JsonModel([
117
            'success' => false,
118
            'data' => 'ERROR_METHOD_NOT_ALLOWED'
119
        ]);
120
    }
121
 
122
    public function commentAction()
123
    {
124
        $id = $this->params()->fromRoute('id');
125
 
126
        $request = $this->getRequest();
127
        if ($request->isPost()) {
128
            $feedMapper = FeedMapper::getInstance($this->adapter);
129
            $now = $feedMapper->getDatebaseNow();
130
 
131
            $feed = $feedMapper->fetchOneByUuid($id);
132
 
133
            if (!$feed) {
134
                $response = [
135
                    'success' => false,
136
                    'data' => 'ERROR_POST_NOT_FOUND'
137
                ];
138
                return new JsonModel($response);
139
            }
140
 
141
            $dataPost = $request->getPost()->toArray();
142
            $form = new CommentForm();
143
            $form->setData($dataPost);
144
 
145
            if ($form->isValid()) {
146
                $currentUserPlugin = $this->plugin('currentUserPlugin');
147
                $currentUser = $currentUserPlugin->getUser();
148
 
149
                $dataPost = (array) $form->getData();
150
 
151
 
152
 
153
                $comment = new Comment();
154
                $comment->network_id = $currentUser->network_id;
155
                $comment->comment = $dataPost['comment'];
156
                $comment->user_id = $currentUser->id;
157
                $comment->feed_id = $feed->id;
158
                $comment->relational = Comment::RELATIONAL_FEED;
159
 
160
                $commentMapper = CommentMapper::getInstance($this->adapter);
161
                if ($commentMapper->insert($comment)) {
162
 
163
 
164
                    if ($feed->type == Feed::TYPE_UPDATE) {
165
                        $userMapper = UserMapper::getInstance($this->adapter);
166
                        $ownerFeed = $userMapper->fetchOne($feed->user_id);
167
 
168
                        $notification = new Notification();
169
                        $notification->type = Notification::TYPE_COMMENT_MY_FEED;
170
                        $notification->feed_id = $feed->id;
171
                        $notification->read     = Notification::NO;
172
                        $notification->user_id  = $ownerFeed->id;
173
                        $notification->message  = 'LABEL_COMMENT_MY_FEED';
174
                        $notification->url      = $this->url()->fromRoute('dashboard', ['feed' => $feed->uuid]);
175
 
176
                        $notificationMapper = NotificationMapper::getInstance($this->adapter);
177
                        $notificationMapper->insert($notification);
178
 
179
                        $userNotificationMapper = UserNotificationSettingMapper::getInstance($this->adapter);
180
                        $userNotification = $userNotificationMapper->fetchOne($ownerFeed->id);
181
 
182
                        if ($userNotification && $userNotification->comment_my_feed) {
183
                            $emailTemplateMapper = EmailTemplateMapper::getInstance($this->adapter);
184
                            $emailTemplate = $emailTemplateMapper->fetchOneByCodeAndNetworkId(EmailTemplate::CODE_COMMENT_MY_FEED,  $currentUser->network_id);
185
 
186
                            if ($emailTemplate) {
187
                                $arrayCont = [
188
                                    'firstname'             => $currentUser->first_name,
189
                                    'lastname'              => $currentUser->last_name,
190
                                    'other_user_firstname'  => $ownerFeed->first_name,
191
                                    'other_user_lastname'   => $ownerFeed->last_name,
192
                                    'company_name'          => '',
193
                                    'group_name'            => '',
194
                                    'content'               => '',
195
                                    'code'                  => '',
196
                                    'link'                  => $this->url()->fromRoute('dashboard', ['feed' => $feed->uuid], ['force_canonical' => true])
197
                                ];
198
 
199
                                $email = new QueueEmail($this->adapter);
200
                                $email->processEmailTemplate($emailTemplate, $arrayCont, $ownerFeed->email, trim($ownerFeed->first_name . ' ' . $ownerFeed->last_name));
201
                            }
202
                        }
203
                    }
204
 
205
                    $total_comments = $commentMapper->fetchCountCommentByFeedId($comment->feed_id);
206
 
207
                    $feed->total_comments = $total_comments;
208
                    $feedMapper->update($feed);
209
 
210
                    $response = [
211
                        'success'   => true,
212
                        'data'   => $this->renderComment($comment->id, $now),
213
                        'total_comments' => $total_comments
214
                    ];
215
 
216
                    return new JsonModel($response);
217
                } else {
218
 
219
                    $response = [
220
                        'success'   => false,
221
                        'data'   => $commentMapper->getError()
222
                    ];
223
 
224
                    return new JsonModel($response);
225
                }
226
            } else {
227
                $message = '';;
228
                $form_messages = (array) $form->getMessages();
229
                foreach ($form_messages  as $fieldname => $field_messages) {
230
                    foreach ($field_messages as $key => $value) {
231
                        $message = $value;
232
                    }
233
                }
234
 
235
                $response = [
236
                    'success'   => false,
237
                    'data'   => $message
238
                ];
239
 
240
                return new JsonModel($response);
241
            }
242
        } else {
243
            $response = [
244
                'success' => false,
245
                'data' => 'ERROR_METHOD_NOT_ALLOWED'
246
            ];
247
 
248
            return new JsonModel($response);
249
        }
250
    }
232 efrain 251
 
252
    public function reactionsAction()
253
    {
254
        $id = $this->params()->fromRoute('id');
255
 
256
        $request = $this->getRequest();
257
        $request = $this->getRequest();
258
        if ($request->isGet()) {
283 www 259
 
232 efrain 260
            $currentUserPlugin = $this->plugin('currentUserPlugin');
261
            $currentUser = $currentUserPlugin->getUser();
262
 
345 www 263
 
264
            $storage = \LeadersLinked\Library\Storage::getInstance($this->config, $this->adapter);
265
 
232 efrain 266
            $feedMapper = FeedMapper::getInstance($this->adapter);
267
            $feed = $feedMapper->fetchOneByUuidAndNetworkId($id, $currentUser->network_id);
268
            if (!$feed) {
269
                $response = [
270
                    'success' => false,
271
                    'data' => 'ERROR_POST_NOT_FOUND'
272
                ];
273
                return new JsonModel($response);
274
            }
275
 
276
 
233 efrain 277
            $userMapper = UserMapper::getInstance($this->adapter);
232 efrain 278
 
279
            $items = [];
280
 
281
            $contentReactionMapper = ContentReactionMapper::getInstance($this->adapter);
282
            $records = $contentReactionMapper->fetchAllByFeedId($feed->id);
289 www 283
 
232 efrain 284
 
285
            foreach($records as $record)
286
            {
287
                $user = $userMapper->fetchOne($record->user_id);
288
                if($user && $user->status == User::STATUS_ACTIVE) {
283 www 289
 
232 efrain 290
 
291
                    array_push($items, [
345 www 292
                        'first_name'    => $user->first_name,
293
                        'last_name'     => $user->last_name,
294
                        'email'         => $user->email,
295
                        'image'         => $storage->getUserImage($user),
296
                        'reaction'      => $record->reaction,
232 efrain 297
                    ]);
298
                }
299
            }
300
 
233 efrain 301
            $response = [
302
                'success' => true,
303
                'data' => $items
304
            ];
232 efrain 305
 
233 efrain 306
            return new JsonModel($response);
232 efrain 307
 
308
 
309
 
310
 
311
        } else {
312
            $response = [
313
                'success' => false,
314
                'data' => 'ERROR_METHOD_NOT_ALLOWED'
315
            ];
316
 
317
            return new JsonModel($response);
318
        }
319
    }
1 efrain 320
 
321
    public function shareAction()
322
    {
323
        $id = $this->params()->fromRoute('id');
324
 
325
        $request = $this->getRequest();
326
        if ($request->isPost()) {
327
 
328
            $currentUserPlugin = $this->plugin('currentUserPlugin');
329
            $currentUser = $currentUserPlugin->getUser();
330
 
331
 
332
            $feedMapper = FeedMapper::getInstance($this->adapter);
333
            $feed = $feedMapper->fetchOneByUuidAndNetworkId($id, $currentUser->network_id);
334
            if (!$feed) {
335
                $response = [
336
                    'success' => false,
337
                    'data' => 'ERROR_POST_NOT_FOUND'
338
                ];
339
                return new JsonModel($response);
340
            }
341
 
342
            $dataPost = array_merge($request->getPost()->toArray(), $request->getFiles()->toArray());
343
            $dataPost['company_id'] = $this->params()->fromRoute('company_id');
344
            $dataPost['group_id'] = $this->params()->fromRoute('group_id');
345
            $dataPost['shared_feed_id'] = $feed->id;
346
 
347
 
348
 
349
 
350
            $response = $this->postOrShareFeed($dataPost);
351
            if ($response['success']) {
352
                $feedMapper->incTotalShared($feed->id);
353
                $total_shared = $feedMapper->fetchTotalShared($feed->id);
354
 
355
                $response['total_shared'] = $total_shared;
356
            }
357
 
358
 
359
            return new JsonModel($response);
360
        } else {
361
            $response = [
362
                'success' => false,
363
                'data' => 'ERROR_METHOD_NOT_ALLOWED'
364
            ];
365
        }
366
 
367
        return new JsonModel($response);
368
    }
369
 
370
    public function commentDeleteAction()
371
    {
372
        $request = $this->getRequest();
373
        if ($request->isPost()) {
374
            $currentUserPlugin = $this->plugin('currentUserPlugin');
375
            $currentUser = $currentUserPlugin->getUser();
376
 
377
            $feed_id = $this->params()->fromRoute('id');
378
            $comment = $this->params()->fromRoute('comment');
379
 
380
            $feedMapper = FeedMapper::getInstance($this->adapter);
381
            $feed = $feedMapper->fetchOneByUuidAndNetworkId($feed_id, $currentUser->network_id);
382
 
383
            if ($feed) {
384
 
385
                $commentMapper = CommentMapper::getInstance($this->adapter);
386
                $comment = $commentMapper->fetchOneByUuid($comment);
387
 
388
                if ($comment && $comment->feed_id == $feed->id && $comment->user_id == $currentUser->id) {
389
 
390
                    $comment->status = Comment::STATUS_DELETED;
391
 
392
                    if ($commentMapper->update($comment)) {
393
 
394
                        $total_comments = $commentMapper->fetchCountCommentByFeedId($comment->feed_id);
395
 
396
 
397
                        $feedMapper = FeedMapper::getInstance($this->adapter);
398
                        $feed = $feedMapper->fetchOne($comment->feed_id);
399
                        $feed->total_comments = $total_comments;
400
                        $feedMapper->update($feed);
401
 
402
 
403
 
404
 
405
 
406
                        $response = [
407
                            'success' => true,
408
                            'data' => 'LABEL_COMMENT_WAS_DELETED',
409
                            'total_comments' => $total_comments
410
                        ];
411
                    } else {
412
                        $response = [
413
                            'success' => false,
414
                            'data' => $commentMapper->getError()
415
                        ];
416
                    }
417
                } else {
418
                    $response = [
419
                        'success' => false,
420
                        'data' => 'ERROR_COMMENT_NOT_FOUND'
421
                    ];
422
                }
423
            } else {
424
                $response = [
425
                    'success' => false,
426
                    'data' => 'ERROR_COMMENT_NOT_FOUND'
427
                ];
428
            }
429
        } else {
430
            $response = [
431
                'success' => false,
432
                'data' => 'ERROR_METHOD_NOT_ALLOWED'
433
            ];
434
        }
435
 
436
        return new JsonModel($response);
437
    }
438
 
439
    public function deleteAction()
440
    {
441
        $request = $this->getRequest();
442
        if ($request->isPost()) {
443
            $currentUserPlugin = $this->plugin('currentUserPlugin');
444
            $currentUser = $currentUserPlugin->getUser();
445
 
446
            $feed_id =  $this->params()->fromRoute('id');
447
 
448
            $feedMapper = FeedMapper::getInstance($this->adapter);
449
            $feed = $feedMapper->fetchOneByUuidAndNetworkId($feed_id, $currentUser->network_id);
450
 
451
            if ($feed) {
452
 
453
                if ($feed->user_id && $feed->user_id == $currentUser->id) {
454
 
455
                    return new JsonModel($this->deleteFeed($feed));
456
                } else if ($feed->group_id) {
457
 
458
                    $groupMapper = GroupMapper::getInstance($this->adapter);
459
                    $group = $groupMapper->fetchOne($feed->group_id);
460
                    if ($group && $group->user_id == $currentUser->id) {
461
                        return new JsonModel($this->deleteFeed($feed));
462
                    }
463
                } else if ($feed->company_id) {
464
                    $companyUserMapper = CompanyUserMapper::getInstance($this->adapter);
465
                    $companyUser = $companyUserMapper->fetchOneByCompanyIdAndUserId($feed->company_id, $currentUser->id);
466
                    if ($companyUser) {
467
                        if (in_array($companyUser->type, [CompanyUser::TYPE_OWNER, CompanyUser::TYPE_ADMINISTRATOR, CompanyUser::TYPE_MANAGER])) {
468
                            return new JsonModel($this->deleteFeed($feed));
469
                        }
470
                    }
471
                }
472
 
473
                $response = [
474
                    'success' => false,
475
                    'data' => ' ERROR_UNAUTHORIZED'
476
                ];
477
            } else {
478
                $response = [
479
                    'success' => false,
480
                    'data' => 'ERROR_FEED_NOT_FOUND'
481
                ];
482
            }
483
 
484
            return new JsonModel($response);
485
        } else {
486
            $response = [
487
                'success' => false,
488
                'data' => 'ERROR_METHOD_NOT_ALLOWED'
489
            ];
490
        }
491
 
492
        return new JsonModel($response);
493
    }
494
 
495
    public function addAction()
496
    {
497
        $request = $this->getRequest();
498
        if ($request->isPost()) {
499
            $dataPost = array_merge($request->getPost()->toArray(), $request->getFiles()->toArray());
500
            $dataPost['company_id'] = $this->params()->fromRoute('company_id');
501
            $dataPost['group_id'] = $this->params()->fromRoute('group_id');
502
            $response = $this->postOrShareFeed($dataPost);
503
 
504
 
505
            return new JsonModel($response);
506
        } else {
507
            $response = [
508
                'success' => false,
509
                'data' => 'ERROR_METHOD_NOT_ALLOWED'
510
            ];
511
        }
512
 
513
        return new JsonModel($response);
514
    }
515
 
516
    public function postOrShareFeed($dataPost)
517
    {
518
 
519
 
520
        $currentUserPlugin = $this->plugin('currentUserPlugin');
521
        $currentUser = $currentUserPlugin->getUser();
522
 
523
        $companyId  = empty($dataPost['company_id']) ? '' : $dataPost['company_id'];
524
        $groupId    = empty($dataPost['group_id']) ? '' : $dataPost['group_id'];
525
 
526
 
527
        if ($groupId || $companyId) {
528
            $form = new  CreateGroupCompanyForm($this->adapter);
529
        } else {
530
            $form = new  CreateForm($this->adapter);
531
        }
532
        $form->setData($dataPost);
533
        if ($form->isValid()) {
534
 
535
 
536
 
537
 
538
            $hydrator = new ObjectPropertyHydrator();
539
            $feed = new Feed();
540
            $hydrator->hydrate($dataPost, $feed);
541
 
542
            $company = null;
543
            $group = null;
544
 
545
            if ($companyId) {
546
                $companyMapper = CompanyMapper::getInstance($this->adapter);
547
                $now = $companyMapper->getDatebaseNow();
548
 
549
                $company = $companyMapper->fetchOneByUuidAndNetworkId($companyId, $currentUser->network_id);
550
 
551
 
552
                if (!$company) {
553
                    return [
554
                        'success'   => false,
555
                        'data'   => 'ERROR_COMPANY_NOT_FOUND'
556
                    ];
557
                }
558
 
559
                if ($company->status != Company::STATUS_ACTIVE) {
560
                    return [
561
                        'success'   => false,
562
                        'data'   => 'ERROR_COMPANY_IS_NOT_ACTIVE'
563
                    ];
564
                }
565
 
566
                $companyUserMapper = CompanyUserMapper::getInstance($this->adapter);
567
                $companyUser = $companyUserMapper->fetchOneByCompanyIdAndUserId($company->id, $currentUser->id);
568
 
569
 
570
                if (!$companyUser || $companyUser->status != CompanyUser::STATUS_ACCEPTED) {
571
                    return [
572
                        'success'   => false,
573
                        'data'   => 'ERROR_UNAUTHORIZED'
574
                    ];
575
                }
576
            }
577
 
578
            if ($groupId) {
579
                $groupMapper = GroupMapper::getInstance($this->adapter);
580
                $now = $groupMapper->getDatebaseNow();
581
 
582
                $group = $groupMapper->fetchOneByUuidAndNetworkId($groupId, $currentUser->network_id);
583
 
584
                if (!$group) {
585
                    return [
586
                        'success'   => false,
587
                        'data'   => 'ERROR_GROUP_NOT_FOUND'
588
                    ];
589
                }
590
 
591
                if ($group->status != Group::STATUS_ACTIVE) {
592
                    return [
593
                        'success'   => false,
594
                        'data'   => 'ERROR_GROUP_IS_NOT_ACTIVE'
595
                    ];
596
                }
597
 
598
                $groupMemberMapper = GroupMemberMapper::getInstance($this->adapter);
599
                $groupMember = $groupMemberMapper->fetchOneByGroupIdAndUserId($group->id, $currentUser->id);
600
                if (!$groupMember || !in_array($groupMember->status, [GroupMember::STATUS_ACCEPTED, GroupMember::STATUS_AUTO_JOIN])) {
601
                    return [
602
                        'success'   => false,
603
                        'data'   => 'ERROR_UNAUTHORIZED'
604
                    ];
605
                }
606
            }
607
 
608
            $feed->network_id   = $currentUser->network_id;
609
            $feed->company_id   = $company ? $company->id : null;
610
            $feed->group_id     = $group ? $group->id : null;
611
            $feed->user_id      = $currentUser->id;
612
 
613
            if ($companyId) {
614
                $feed->type = Feed::TYPE_COMPANY;
615
            } else if ($groupId) {
616
                $feed->type = Feed::TYPE_GROUP;
617
            } else {
618
                $feed->type = Feed::TYPE_UPDATE;
619
            }
620
 
621
            $posted_or_shared   = $dataPost['posted_or_shared'];
622
            if ($posted_or_shared != Feed::POSTED && $posted_or_shared != Feed::SHARED) {
623
                return [
624
                    'success'   => false,
625
                    'data'      => 'ERROR_SUPPLY_VALID_SHARING_STATUS'
626
                ];
627
            }
628
            $feed->posted_or_shared = $posted_or_shared;
629
            $feedMapper = FeedMapper::getInstance($this->adapter);
630
            $now = $feedMapper->getDatebaseNow();
631
 
632
            $shared_with = isset($dataPost['shared_with']) ? $dataPost['shared_with'] : Feed::SHARE_WITH_PUBLIC;
633
            if ($shared_with != Feed::SHARE_WITH_PUBLIC && $shared_with != Feed::SHARE_WITH_CONNECTIONS) {
634
                return [
635
                    'status' => false,
636
                    'error' => 'ERROR_SUPPLY_VALID_SHARING_WITH_TYPE',
637
                ];
638
            }
639
 
640
            $feed->shared_with = $shared_with;
641
            if (Feed::SHARED == $feed->posted_or_shared) {
642
                $shared_feed_id     = empty($dataPost['shared_feed_id']) ? 0 : $dataPost['shared_feed_id'];
643
 
644
 
645
                $sharedFeed = $feedMapper->fetchOneByIdAndNetworkId($shared_feed_id, $currentUser->network_id);
646
                if (!$sharedFeed) {
647
                    return [
648
                        'status' => false,
649
                        'error' => 'ERROR_POST_SHARE',
650
                    ];
651
                }
652
 
653
                $feed->shared_feed_id       = $sharedFeed->id;
654
                $feed->shared_company_id    = $sharedFeed->shared_company_id;
655
                $feed->shared_group_id      = $sharedFeed->shared_group_id;
656
                $feed->shared_job_id        = $sharedFeed->shared_job_id;
657
            } else {
658
                $sharedFeed = null;
659
            }
660
 
661
            $feed->status = Feed::STATUS_PUBLISHED;
662
            $feed->total_comments    = 0;
663
            $feed->total_shared     = 0;
664
 
345 www 665
 
666
            $storage = Storage::getInstance($this->config, $this->adapter);
667
            $storage->setCurrentFilename('file');
668
 
669
 
670
 
334 www 671
            $files = $this->getRequest()->getFiles()->toArray();
345 www 672
 
673
 
283 www 674
            if (isset($files['file']) && empty($files['file']['error'])) {
334 www 675
 
345 www 676
 
677
 
678
 
679
                $feed_tmp_filename  = $files['file']['tmp_name'];
680
                $feed_filename      = \LeadersLinked\Library\Functions::normalizeStringFilename($files['file']['name']);
681
 
682
                $mime_type = mime_content_type($feed_tmp_filename);
283 www 683
                if ($mime_type == 'image/jpg' || $mime_type == 'image/jpeg' || $mime_type == 'image/png') {
345 www 684
                    $file_type = Storage::FILE_TYPE_IMAGE;
334 www 685
                } else if ($mime_type == 'video/quicktime' ||  $mime_type == 'video/webm' || $mime_type == 'video/mpeg' || $mime_type == 'video/mpg' || $mime_type == 'video/mp4') {
345 www 686
                    $file_type = Storage::FILE_TYPE_VIDEO;
283 www 687
                } else if ($mime_type == 'application/pdf') {
345 www 688
                    $file_type = Storage::FILE_TYPE_DOCUMENT;
1 efrain 689
                }
690
            }
345 www 691
 
1 efrain 692
 
693
 
694
            $result = $feedMapper->insert($feed);
695
            if ($result) {
696
 
697
                if ($sharedFeed && $sharedFeed->type == Feed::TYPE_UPDATE) {
698
 
699
 
700
                    $userMapper = UserMapper::getInstance($this->adapter);
701
                    $ownerFeed = $userMapper->fetchOne($sharedFeed->user_id);
702
 
703
                    $notification = new Notification();
704
                    $notification->type     = Notification::TYPE_SHARE_MY_FEED;
705
                    $notification->read     = Notification::NO;
706
                    $notification->user_id  = $ownerFeed->id;
707
                    $notification->feed_id = $feed->id;
708
                    $notification->message  = 'LABEL_SHARE_MY_FEED';
709
                    $notification->url      = $this->url()->fromRoute('dashboard', ['feed' => $sharedFeed->uuid]);
710
 
711
                    $notificationMapper = NotificationMapper::getInstance($this->adapter);
712
                    $notificationMapper->insert($notification);
713
 
714
                    $userNotificationMapper = UserNotificationSettingMapper::getInstance($this->adapter);
715
                    $userNotification = $userNotificationMapper->fetchOne($ownerFeed->id);
716
 
717
                    if ($userNotification && $userNotification->share_my_feed) {
718
                        $emailTemplateMapper = EmailTemplateMapper::getInstance($this->adapter);
719
                        $emailTemplate = $emailTemplateMapper->fetchOneByCodeAndNetworkId(EmailTemplate::CODE_SHARE_MY_FEED, $currentUser->network_id);
720
 
721
                        if ($emailTemplate) {
722
                            $arrayCont = [
723
                                'firstname'             => $currentUser->first_name,
724
                                'lastname'              => $currentUser->last_name,
725
                                'other_user_firstname'  => $ownerFeed->first_name,
726
                                'other_user_lastname'   => $ownerFeed->last_name,
727
                                'company_name'          => '',
728
                                'group_name'            => '',
729
                                'content'               => '',
730
                                'code'                  => '',
731
                                'link'                  => $this->url()->fromRoute('dashboard', ['feed' => $feed->uuid], ['force_canonical' => true])
732
                            ];
733
 
734
                            $email = new QueueEmail($this->adapter);
735
                            $email->processEmailTemplate($emailTemplate, $arrayCont, $ownerFeed->email, trim($ownerFeed->first_name . ' ' . $ownerFeed->last_name));
736
                        }
737
                    }
738
                }
739
 
740
 
741
                $feed = $feedMapper->fetchOne($feed->id);
302 www 742
 
345 www 743
                $storage = Storage::getInstance($this->config, $this->adapter);
744
                $storage->setFiles($this->getRequest()->getFiles()->toArray());
745
 
746
                if($storage->setCurrentFilename('file')) {
747
                    $file_type          = $storage->getFileType();
748
                    $source_filename    = $storage->getTmpFilename();
749
                    $filename           = $storage->getFilename();
283 www 750
 
334 www 751
 
345 www 752
                    if ($file_type == Storage::FILE_TYPE_DOCUMENT) {
283 www 753
 
345 www 754
                        $target_filename = $storage->composePathToFilename(Storage::TYPE_FEED, $feed->uuid, $filename);
334 www 755
 
756
 
345 www 757
                        if ($storage->putFile($source_filename,$target_filename)) {
758
                            $feed->file_type = $file_type;
334 www 759
                            $feed->file_name = $filename;
302 www 760
                            $feedMapper->update($feed);
761
                        }
283 www 762
 
345 www 763
                    } else if ($file_type == Storage::FILE_TYPE_IMAGE) {
764
                        $filename = $storage->getFilenamePNG();
765
                        $target_filename = $storage->composePathToFilename(Storage::TYPE_FEED, $feed->uuid, $filename);
766
 
302 www 767
                        list($target_width, $target_height) = explode('x', $this->config['leaderslinked.image_sizes.feed_image_size']);
768
 
345 www 769
                        if($storage->uploadImageResize($source_filename, $target_filename, $target_width, $target_height)) {
770
                            $feed->file_type = $file_type;
771
                            $feed->file_name = $filename;
772
                            $feedMapper->update($feed);
773
                        }
774
                    } else if ($file_type == Storage::FILE_TYPE_VIDEO) {
334 www 775
 
345 www 776
                        $source_filename    = $storage->getTmpFilename();
777
                        $filename           = $storage->getFilename();
334 www 778
 
345 www 779
                        $target_filename    = $storage->composePathToFilename(Storage::TYPE_FEED, $feed->uuid, $filename);
334 www 780
 
345 www 781
                        if($storage->moveUploadedFile($source_filename, $target_filename )) {
782
                            $feed->file_type = $file_type;
783
                            $feed->file_name = $filename;
302 www 784
 
785
 
345 www 786
                            $filename           = $storage->getFilenamePNG();
787
                            $source_filename    = $target_filename;
788
                            $target_filename    = $storage->composePathToFilename(Storage::TYPE_FEED, $feed->uuid, $filename);
302 www 789
 
345 www 790
                            if($storage->extractPosterFromVideo($source_filename, $target_filename)) {
791
 
792
                                $feed->file_image_preview = $filename;
302 www 793
                            }
794
 
334 www 795
 
345 www 796
                            if($feedMapper->update($feed)) {
797
 
798
                                $videoConvert               = new VideoConvert();
799
                                $videoConvert->uuid         = $feed->uuid;
800
                                $videoConvert->filename     = $feed->file_name;
801
                                $videoConvert->type         = VideoConvert::TYPE_FEED;
802
 
803
                                $videoConvertMapper = VideoConvertMapper::getInstance($this->adapter);
804
                                $videoConvertMapper->insert($videoConvert);
805
                            }
1 efrain 806
                        }
345 www 807
 
1 efrain 808
                    }
334 www 809
 
1 efrain 810
                }
811
 
812
                return [
813
                    'success'   => true,
814
                    'data'   => $this->renderFeed($feed->id, $now)
815
                ];
816
            } else {
817
                return [
818
                    'success'   => false,
819
                    'data'   => $feedMapper->getError()
820
                ];
821
            }
822
        } else {
823
            $messages = [];
824
            $form_messages = (array) $form->getMessages();
825
            foreach ($form_messages  as $fieldname => $field_messages) {
826
                $messages[$fieldname] = array_values($field_messages);
827
            }
828
 
829
            return [
830
                'success'   => false,
831
                'data'   => $messages
832
            ];
833
        }
834
    }
835
 
836
    public function saveReactionAction()
837
    {
838
        $id = $this->params()->fromRoute('id');
839
       // $reaction  = $this->params()->fromRoute('reaction');
840
        $reaction  = $this->params()->fromPost('reaction');
841
 
842
        $request = $this->getRequest();
843
        if ($request->isPost()) {
844
            $currentUserPlugin = $this->plugin('currentUserPlugin');
845
            $currentUser = $currentUserPlugin->getUser();
846
 
847
 
848
            $feedMapper = FeedMapper::getInstance($this->adapter);
849
            $feed = $feedMapper->fetchOneByUuidAndNetworkId($id, $currentUser->network_id);
850
            if (!$feed) {
851
                $response = [
852
                    'success' => false,
853
                    'data' => 'ERROR_POST_NOT_FOUND'
854
                ];
855
                return new JsonModel($response);
856
            }
857
 
858
            $reactions = [
859
                ContentReaction::REACTION_RECOMMENDED,
860
                ContentReaction::REACTION_SUPPORT,
861
                ContentReaction::REACTION_LOVE,
862
                ContentReaction::REACTION_INTEREST,
863
                ContentReaction::REACTION_FUN
864
 
865
            ];
866
            if(!in_array($reaction, $reactions)) {
867
                $response = [
868
                    'success' => false,
869
                    'data' => 'ERROR_REACTION_NOT_FOUND'
870
                ];
871
                return new JsonModel($response);
872
            }
873
 
874
 
875
            $contentReactionMapper = ContentReactionMapper::getInstance($this->adapter);
876
            $contentReaction = $contentReactionMapper->fetchOneByFeedIdAndUserId($feed->id, $currentUser->id);
877
 
878
            if ($contentReaction) {
879
                $contentReaction->reaction = $reaction;
880
                $result = $contentReactionMapper->update($contentReaction);
881
            } else {
882
                $contentReaction = new ContentReaction();
883
                $contentReaction->user_id = $currentUser->id;
884
                $contentReaction->feed_id = $feed->id;
885
                $contentReaction->relational = ContentReaction::RELATIONAL_FEED;
886
                $contentReaction->reaction = $reaction;
887
 
888
                $result = $contentReactionMapper->insert($contentReaction);
889
            }
890
 
891
 
892
 
893
            if ($result) {
894
 
895
                $reactions = $contentReactionMapper->fetchCountByFeedId($feed->id);
896
                $response = [
897
                    'success' => true,
898
                    'data' => [
899
                        'reactions' => $reactions
900
                    ]
901
                ];
902
            } else {
903
                $response = [
904
                    'success' => false,
905
                    'data' => $contentReactionMapper->getError()
906
                ];
907
            }
908
            return new JsonModel($response);
909
        }
910
 
911
        $response = [
912
            'success' => false,
913
            'data' => 'ERROR_METHOD_NOT_ALLOWED'
914
        ];
915
        return new JsonModel($response);
916
    }
917
 
918
    public function deleteReactionAction()
919
    {
920
        $id = $this->params()->fromRoute('id');
921
 
922
        $request = $this->getRequest();
923
        if ($request->isPost()) {
924
            $currentUserPlugin = $this->plugin('currentUserPlugin');
925
            $currentUser = $currentUserPlugin->getUser();
926
 
927
            $feedMapper = FeedMapper::getInstance($this->adapter);
928
            $feed = $feedMapper->fetchOneByUuidAndNetworkId($id, $currentUser->network_id);
929
            if (!$feed) {
930
                $response = [
931
                    'success' => false,
932
                    'data' => 'ERROR_POST_NOT_FOUND'
933
                ];
934
                return new JsonModel($response);
935
            }
936
 
937
            $contentReactionMapper = ContentReactionMapper::getInstance($this->adapter);
938
            $contentReaction = $contentReactionMapper->fetchOneByFeedIdAndUserId($feed->id, $currentUser->id);
939
 
940
            if (!$contentReaction) {
941
                $response = [
942
                    'success' => false,
943
                    'data' => 'ERROR_DUPLICATE_ACTION'
944
                ];
945
                return new JsonModel($response);
946
            }
947
 
948
            if ($contentReactionMapper->deleteByFeedIdAndUserId($feed->id, $currentUser->id)) {
949
                $reactions = $contentReactionMapper->fetchCountByFeedId($feed->id);
950
 
951
 
952
                $response = [
953
                    'success' => true,
954
                    'data' => [
955
                        'reactions' => $reactions
956
                    ]
957
                ];
958
            } else {
959
                $response = [
960
                    'success' => false,
961
                    'data' => $contentReactionMapper->getError()
962
                ];
963
            }
964
            return new JsonModel($response);
965
        }
966
 
967
        $response = [
968
            'success' => false,
969
            'data' => 'ERROR_METHOD_NOT_ALLOWED'
970
        ];
971
        return new JsonModel($response);
972
    }
973
 
974
    /*
975
    public function likeAction()
976
    {
977
        $id = $this->params()->fromRoute('id');
978
 
979
        $request = $this->getRequest();
980
        if ($request->isPost()) {
981
            $currentUserPlugin = $this->plugin('currentUserPlugin');
982
            $currentUser = $currentUserPlugin->getUser();
983
 
984
 
985
            $feedMapper = FeedMapper::getInstance($this->adapter);
986
            $feed = $feedMapper->fetchOneByUuidAndNetworkId($id, $currentUser->network_id);
987
            if (!$feed) {
988
                $response = [
989
                    'success' => false,
990
                    'data' => 'ERROR_POST_NOT_FOUND'
991
                ];
992
                return new JsonModel($response);
993
            }
994
 
995
            $contentReactionMapper = ContentReactionMapper::getInstance($this->adapter);
996
            $contentReaction =  $contentReactionMapper->fetchOneByFeedIdAndUserId($feed->id, $currentUser->id);
997
 
998
            if ($contentReaction) {
999
                $response = [
1000
                    'success' => false,
1001
                    'data' => 'ERROR_DUPLICATE_ACTION'
1002
                ];
1003
                return new JsonModel($response);
1004
            }
1005
 
1006
            $contentReaction = new Like();
1007
            $contentReaction->user_id = $currentUser->id;
1008
            $contentReaction->feed_id = $feed->id;
1009
            $contentReaction->relational = Like::RELATIONAL_FEED;
1010
 
1011
            if ($contentReactionMapper->insert($contentReaction)) {
1012
 
1013
                $contentReactions = $contentReactionMapper->fetchCountLikeByFeedId($feed->id);
1014
 
1015
 
1016
 
1017
                if ($feed->type == Feed::TYPE_UPDATE) {
1018
 
1019
 
1020
                    $userMapper = UserMapper::getInstance($this->adapter);
1021
                    $ownerFeed = $userMapper->fetchOne($feed->user_id);
1022
 
1023
                    $notification = new Notification();
1024
                    $notification->type     = Notification::TYPE_LIKE_MY_FEED;
1025
                    $notification->read     = Notification::NO;
1026
                    $notification->user_id  = $feed->user_id;
1027
                    $notification->feed_id  = $feed->id;
1028
                    $notification->message  = 'LABEL_LIKE_MY_FEED';
1029
                    $notification->url      = $this->url()->fromRoute('dashboard', ['feed' => $feed->uuid]);
1030
 
1031
                    $notificationMapper = NotificationMapper::getInstance($this->adapter);
1032
                    $notificationMapper->insert($notification);
1033
 
1034
                    $userNotificationMapper = UserNotificationSettingMapper::getInstance($this->adapter);
1035
                    $userNotification = $userNotificationMapper->fetchOne($ownerFeed->id);
1036
 
1037
                    if ($userNotification && $userNotification->like_my_feed) {
1038
                        $emailTemplateMapper = EmailTemplateMapper::getInstance($this->adapter);
1039
                        $emailTemplate = $emailTemplateMapper->fetchOneByCodeAndNetworkId(EmailTemplate::CODE_LIKE_MY_FEED, $currentUser->network_id);
1040
 
1041
                        if ($emailTemplate) {
1042
                            $arrayCont = [
1043
                                'firstname'             => $currentUser->first_name,
1044
                                'lastname'              => $currentUser->last_name,
1045
                                'other_user_firstname'  => $ownerFeed->first_name,
1046
                                'other_user_lastname'   => $ownerFeed->last_name,
1047
                                'company_name'          => '',
1048
                                'group_name'            => '',
1049
                                'content'               => '',
1050
                                'code'                  => '',
1051
                                'link'                  => $this->url()->fromRoute('dashboard', ['feed' => $feed->uuid], ['force_canonical' => true])
1052
                            ];
1053
 
1054
                            $email = new QueueEmail($this->adapter);
1055
                            $email->processEmailTemplate($emailTemplate, $arrayCont, $ownerFeed->email, trim($ownerFeed->first_name . ' ' . $ownerFeed->last_name));
1056
                        }
1057
                    }
1058
                }
1059
 
1060
 
1061
 
1062
 
1063
 
1064
 
1065
 
1066
 
1067
                $response = [
1068
                    'success' => true,
1069
                    'data' => [
1070
                        'likes' => $contentReactions
1071
                    ]
1072
                ];
1073
            } else {
1074
                $response = [
1075
                    'success' => false,
1076
                    'data' => $contentReactionMapper->getError()
1077
                ];
1078
            }
1079
            return new JsonModel($response);
1080
        }
1081
 
1082
        $response = [
1083
            'success' => false,
1084
            'data' => 'ERROR_METHOD_NOT_ALLOWED'
1085
        ];
1086
        return new JsonModel($response);
1087
    }
1088
 
1089
    public function unlikeAction()
1090
    {
1091
        $id = $this->params()->fromRoute('id');
1092
 
1093
        $request = $this->getRequest();
1094
        if ($request->isPost()) {
1095
            $currentUserPlugin = $this->plugin('currentUserPlugin');
1096
            $currentUser = $currentUserPlugin->getUser();
1097
 
1098
            $feedMapper = FeedMapper::getInstance($this->adapter);
1099
            $feed = $feedMapper->fetchOneByUuidAndNetworkId($id, $currentUser->network_id);
1100
            if (!$feed) {
1101
                $response = [
1102
                    'success' => false,
1103
                    'data' => 'ERROR_POST_NOT_FOUND'
1104
                ];
1105
                return new JsonModel($response);
1106
            }
1107
 
1108
            $contentReactionMapper = LikeMapper::getInstance($this->adapter);
1109
            $contentReaction = $contentReactionMapper->fetchOneByFeedIdAndUserId($feed->id, $currentUser->id);
1110
 
1111
            if (!$contentReaction) {
1112
                $response = [
1113
                    'success' => false,
1114
                    'data' => 'ERROR_DUPLICATE_ACTION'
1115
                ];
1116
                return new JsonModel($response);
1117
            }
1118
 
1119
            if ($contentReactionMapper->deleteByFeedIdAndUserId($feed->id, $currentUser->id)) {
1120
                $contentReactions = $contentReactionMapper->fetchCountLikeByFeedId($feed->id);
1121
 
1122
 
1123
                $response = [
1124
                    'success' => true,
1125
                    'data' => [
1126
                        'likes' => $contentReactions
1127
                    ]
1128
                ];
1129
            } else {
1130
                $response = [
1131
                    'success' => false,
1132
                    'data' => $contentReactionMapper->getError()
1133
                ];
1134
            }
1135
            return new JsonModel($response);
1136
        }
1137
 
1138
        $response = [
1139
            'success' => false,
1140
            'data' => 'ERROR_METHOD_NOT_ALLOWED'
1141
        ];
1142
        return new JsonModel($response);
1143
    }*/
1144
 
1145
    public function timelineAction()
1146
    {
1147
 
1148
 
192 efrain 1149
 
1150
 
1151
 
1 efrain 1152
        $currentUserPlugin = $this->plugin('currentUserPlugin');
1153
        $currentUser = $currentUserPlugin->getUser();
1154
 
1155
 
1156
        $type   = $this->params()->fromRoute('type');
1157
        if ($type == 'user') {
1158
            $id = $currentUser->id;
1159
        } else {
1160
            $id     = $this->params()->fromRoute('id');
1161
        }
1162
 
1163
        $feedHighlighted = 0;
1164
        $feedUuid = $this->params()->fromRoute('feed');
1165
 
1166
 
1167
 
1168
        if ($feedUuid) {
1169
            $feedMapper = FeedMapper::getInstance($this->adapter);
1170
            $now = $feedMapper->getDatebaseNow();
1171
 
1172
            $feed = $feedMapper->fetchOneByUuidAndNetworkIdAnyStatus($feedUuid, $currentUser->network_id);
1173
 
1174
            if ($feed) {
1175
                $feedHighlighted = $feed->id;
1176
            }
1177
        }
1178
 
1179
 
1180
 
1181
        $request = $this->getRequest();
1182
        if ($request->isGet()) {
1183
 
192 efrain 1184
            $userBlockedMapper = UserBlockedMapper::getInstance($this->adapter);
1185
            $user_blocked_ids = $userBlockedMapper->fetchAllBlockedReturnIds($currentUser->id);
1186
 
1187
            $abuseReportMapper = AbuseReportMapper::getInstance($this->adapter);
1188
            $abuse_report_feed_ids = $abuseReportMapper->fetchAllDataByUserReportingIdAndTypeReturnIds($currentUser->id, AbuseReport::TYPE_FEED);
1189
 
1190
            $abuse_report_comment_ids = $abuseReportMapper->fetchAllDataByUserReportingIdAndTypeReturnIds($currentUser->id, AbuseReport::TYPE_COMMENT);
1191
 
1192
 
1193
 
1 efrain 1194
            $exclude_feed_ids = [];
1195
 
1196
            $queryMapper = QueryMapper::getInstance($this->adapter);
1197
 
1198
            $selectNotUserCompany = $queryMapper->getSql()->select();
1199
            $selectNotUserCompany->columns(['company_id']);
1200
            $selectNotUserCompany->from(['cu' => CompanyUserMapper::_TABLE]);
1201
 
1202
            $selectNotUserCompany->where->equalTo('user_id', $currentUser->id);
1203
            $selectNotUserCompany->where->in('status', [CompanyUser::STATUS_ACCEPTED, CompanyUser::STATUS_ADMIN_WILL_ADD]);
1204
 
1205
 
1206
 
1207
 
1208
 
1209
            $select = $queryMapper->getSql()->select();
1210
            $select->columns(['id']);
1211
            $select->from(['f' => FeedMapper::_TABLE]);
1212
            $select->join(['fs' => FastSurveyMapper::_TABLE], 'fs.id = f.fast_survey_id', []);
1213
            $select->where->equalTo('f.file_type', Feed::FILE_TYPE_FAST_SURVEY);
1214
            $select->where->equalTo('f.network_id', $currentUser->network_id);
1215
            $select->where->equalTo('f.status', Feed::STATUS_PUBLISHED);
1216
            $select->where->equalTo('fs.privacy', FastSurvey::PRIVACY_COMPANY);
1217
            $select->where->notIn('fs.company_id', $selectNotUserCompany);
1218
 
1219
            $records = $queryMapper->fetchAll($select);
1220
            foreach($records as $record)
1221
            {
1222
                array_push($exclude_feed_ids, $record['id']);
1223
            }
1224
 
1225
 
1226
            $page = (int) $this->params()->fromQuery('page');
1227
            if ($type == 'user') {
1228
                $connectionMapper = ConnectionMapper::getInstance($this->adapter);
1229
                $now = $connectionMapper->getDatebaseNow();
1230
 
1231
                $records = $connectionMapper->fetchAllConnectionsByUser($id);
1232
                $connectionIds = [0];
1233
                foreach ($records as $record) {
1234
                    if ($currentUser->id == $record->request_from) {
1235
                        array_push($connectionIds, $record->request_to);
1236
                    } else {
1237
                        array_push($connectionIds, $record->request_from);
1238
                    }
1239
                }
1240
                array_push($connectionIds, 1);
1241
 
1242
                $companyFollowerMapper = CompanyFollowerMapper::getInstance($this->adapter);
1243
                $records = $companyFollowerMapper->fetchAllByFollowerId($currentUser->id);
1244
 
1245
                $companyIds = [0];
1246
                foreach ($records as $record) {
1247
                    if (!in_array($record->company_id, $companyIds)) {
1248
                        array_push($companyIds, $record->company_id);
1249
                    }
1250
                }
1251
 
1252
                $companyUserMapper = CompanyUserMapper::getInstance($this->adapter);
1253
                $companyUsers = $companyUserMapper->fetchAllByUserId($currentUser->id);
1254
 
1255
                foreach ($companyUsers as $companyUser) {
1256
                    if ($companyUser->status == CompanyUser::STATUS_ACCEPTED) {
1257
                        if (!in_array($companyUser->company_id, $companyIds)) {
1258
                            array_push($companyIds, $companyUser->company_id);
1259
                        }
1260
                    }
1261
                }
1262
 
1263
 
1264
                $groupMemberMapper = GroupMemberMapper::getInstance($this->adapter);
1265
                $groupMembers = $groupMemberMapper->fetchAllByUserId($currentUser->id);
1266
 
1267
                $groupIds = [0];
1268
 
1269
                foreach ($groupMembers as $groupMember) {
1270
                    if ($groupMember->status == GroupMember::STATUS_ACCEPTED) {
1271
                        if (!in_array($groupMember->group_id, $groupIds)) {
1272
                            array_push($groupIds, $groupMember->group_id);
1273
                        }
1274
                    }
1275
                }
1276
 
1277
                $queryMapper = QueryMapper::getInstance($this->adapter);
1278
                $select = $queryMapper->getSql()->select(FeedMapper::_TABLE);
1279
                $select->columns(['id']);
1280
                $select->where->equalTo('network_id', $currentUser->network_id);
1281
                $select->where->equalTo('status', Feed::STATUS_PUBLISHED)
1282
                    ->AND->NEST
1283
                    ->OR->NEST->equalTo('user_id', $id)->and->equalTo('type', Feed::TYPE_UPDATE)->UNNEST
1284
                    ->OR->NEST->and->equalTo('type', Feed::TYPE_UPDATE)->and->equalTo('shared_with', Feed::SHARE_WITH_PUBLIC)->UNNEST
1285
                    ->OR->NEST->in('user_id', $connectionIds)->and->equalTo('type', Feed::TYPE_UPDATE)->and->equalTo('shared_with', Feed::SHARE_WITH_CONNECTIONS)->UNNEST
1286
                    ->OR->NEST->or->in('company_id', $companyIds)->and->equalTo('type', Feed::TYPE_COMPANY)->UNNEST
1287
                    ->OR->NEST->or->in('group_id', $groupIds)->and->equalTo('type', Feed::TYPE_GROUP)->UNNEST
1288
                    ->UNNEST;
1289
 
1290
                if($exclude_feed_ids) {
1291
                    $select->where->notIn('id', $exclude_feed_ids);
1292
                }
192 efrain 1293
                if($abuse_report_feed_ids) {
1294
                    $select->where->notIn('id', $abuse_report_feed_ids);
1295
                }
1296
                if($user_blocked_ids) {
1297
                    $select->where->notIn('user_id', $user_blocked_ids);
1298
                }
1 efrain 1299
 
1300
 
1301
                $select->order('added_on desc');
1302
            }
1303
            if ($type == 'company') {
1304
                $companyMapper = CompanyMapper::getInstance($this->adapter);
1305
                $now = $companyMapper->getDatebaseNow();
1306
 
1307
                $company = $companyMapper->fetchOneByUuidAndNetworkId($id, $currentUser->network_id);
1308
 
1309
                if (!$company || $company->status != Company::STATUS_ACTIVE) {
1310
                    $id = 0;
1311
                } else {
1312
                    $companyFollowerMapper = CompanyFollowerMapper::getInstance($this->adapter);
1313
                    $companyFollower = $companyFollowerMapper->fetchOneByCompanyIdAndUserId($company->id, $currentUser->id);
1314
                    if ($companyFollower) {
1315
                        $id = $company->id;
1316
                    } else {
1317
 
1318
                        $companyUserMapper = CompanyUserMapper::getInstance($this->adapter);
1319
                        $companyUser = $companyUserMapper->fetchOneByCompanyIdAndUserId($company->id, $currentUser->id);
1320
 
1321
                        if (!$companyUser || $companyUser->status != CompanyUser::STATUS_ACCEPTED) {
1322
                            $id = 0;
1323
                        } else {
1324
                            $id = $company->id;
1325
                        }
1326
                    }
1327
                }
1328
 
1329
 
1330
 
1331
                $select = $queryMapper->getSql()->select(FeedMapper::_TABLE);
1332
                $select->columns(['id']);
1333
                $select->where->equalTo('network_id', $currentUser->network_id);
1334
                $select->where->equalTo('status', Feed::STATUS_PUBLISHED);
1335
                $select->where->equalTo('company_id', $id);
1336
                $select->where->and->equalTo('type', Feed::TYPE_COMPANY);
1337
 
1338
                if($exclude_feed_ids) {
1339
                    $select->where->notIn('id', $exclude_feed_ids);
1340
                }
192 efrain 1341
                if($abuse_report_feed_ids) {
1342
                    $select->where->notIn('id', $abuse_report_feed_ids);
1343
                }
1344
                if($user_blocked_ids) {
1345
                    $select->where->notIn('user_id', $user_blocked_ids);
1346
                }
1 efrain 1347
 
1348
                $select->order('added_on desc');
1349
            }
1350
            if ($type == 'group') {
1351
                $groupMapper = GroupMapper::getInstance($this->adapter);
1352
                $now = $groupMapper->getDatebaseNow();
1353
 
1354
                $group = $groupMapper->fetchOneByUuidAndNetworkId($id, $currentUser->network_id);
1355
 
1356
                $id = 0;
1357
 
1358
                if ($group && $group->status == Group::STATUS_ACTIVE) {
1359
                    $groupMemberMapper = GroupMemberMapper::getInstance($this->adapter);
1360
                    $groupMember = $groupMemberMapper->fetchOneByGroupIdAndUserId($group->id, $currentUser->id);
1361
                    if ($groupMember) {
1362
 
1363
 
1364
                        if (
1365
                            $groupMember->status == GroupMember::STATUS_ACCEPTED ||
1366
                            $groupMember->status == GroupMember::STATUS_AUTO_JOIN
1367
                        ) {
1368
 
1369
                            $id =  $groupMember->group_id;
1370
                        }
1371
                    }
1372
                }
1373
 
1374
                $queryMapper = QueryMapper::getInstance($this->adapter);
1375
                $select = $queryMapper->getSql()->select(FeedMapper::_TABLE);
1376
                $select->columns(['id']);
1377
                $select->where->equalTo('network_id', $currentUser->network_id);
1378
                $select->where->equalTo('status', Feed::STATUS_PUBLISHED);
1379
                $select->where->equalTo('group_id', $id);
1380
                $select->where->nest()->equalTo('type', Feed::TYPE_GROUP)
1381
                ->or->equalTo('type', Feed::TYPE_UPDATE)->unnest();
1382
 
1383
                if($exclude_feed_ids) {
1384
                    $select->where->notIn('id', $exclude_feed_ids);
1385
                }
192 efrain 1386
                if($abuse_report_feed_ids) {
1387
                    $select->where->notIn('id', $abuse_report_feed_ids);
1388
                }
1389
                if($user_blocked_ids) {
1390
                    $select->where->notIn('user_id', $user_blocked_ids);
1391
                }
1 efrain 1392
 
1393
                $select->order('added_on desc');
1394
            }
1395
 
1396
            $dbSelect = new DbSelect($select, $this->adapter);
1397
            $paginator = new Paginator($dbSelect);
1398
            $paginator->setCurrentPageNumber($page ? $page : 1);
1399
            $paginator->setItemCountPerPage(10);
1400
 
1401
            $items = [];
1402
 
1403
 
1404
            if ($feedHighlighted) {
1405
 
1406
 
192 efrain 1407
                $items[] = $this->renderFeed($feedHighlighted, $now, $feedHighlighted,  $user_blocked_ids , $abuse_report_comment_ids);
1 efrain 1408
            }
1409
 
1410
            $feeds = $paginator->getCurrentItems();
1411
            foreach ($feeds as $feed) {
192 efrain 1412
                $items[] = $this->renderFeed($feed->id, $now, $feedHighlighted,  $user_blocked_ids , $abuse_report_comment_ids);
1 efrain 1413
            }
1414
 
1415
            $response = [
1416
                'success' => true,
1417
                'data' => [
1418
                    'total' => [
1419
                        'count' => $paginator->getTotalItemCount(),
1420
                        'pages' => $paginator->getPages()->pageCount,
1421
                    ],
1422
                    'current' => [
1423
                        'items'    => $items,
1424
                        'page'     => $paginator->getCurrentPageNumber(),
1425
                        'count'    => $paginator->getCurrentItemCount(),
1426
                    ]
1427
                ]
1428
            ];
1429
 
1430
 
1431
 
1432
            /*
1433
            if($feedHighlighted) {
1434
 
1435
 
1436
                $items[] = $this->renderFeed($feedHighlighted, $now, $feedHighlighted);
1437
 
1438
                $response = [
1439
                    'success' => true,
1440
                    'data' => [
1441
                        'total' => [
1442
                            'count' => 1,
1443
                            'pages' => 1,
1444
                        ],
1445
                        'current' => [
1446
                            'items'    => $items,
1447
                            'page'     => 1,
1448
                            'count'    => 1,
1449
                        ]
1450
                    ]
1451
                ];
1452
            } else {
1453
 
1454
 
1455
 
1456
                $feeds = $paginator->getCurrentItems();
1457
                foreach($feeds as $feed)
1458
                {
1459
                    $items[] = $this->renderFeed($feed->id, $now, $feedHighlighted);
1460
                }
1461
 
1462
                $response = [
1463
                    'success' => true,
1464
                    'data' => [
1465
                        'total' => [
1466
                            'count' => $paginator->getTotalItemCount(),
1467
                            'pages' => $paginator->getPages()->pageCount,
1468
                        ],
1469
                        'current' => [
1470
                            'items'    => $items,
1471
                            'page'     => $paginator->getCurrentPageNumber(),
1472
                            'count'    => $paginator->getCurrentItemCount(),
1473
                        ]
1474
                    ]
1475
                ];
1476
            }*/
1477
 
1478
 
1479
 
1480
            return new JsonModel($response);
1481
        }
1482
 
1483
        $response = [
1484
            'success' => false,
1485
            'data' => 'ERROR_METHOD_NOT_ALLOWED'
1486
        ];
1487
 
1488
 
1489
        return new JsonModel($response);
1490
    }
1491
 
1492
 
1493
 
1494
 
1495
    /**
1496
     *
1497
     * @param int $feed_id
192 efrain 1498
     * @param int[] $user_blocked_ids
1499
     * @param int[] $abuse_report_comment_ids
1 efrain 1500
     * @return array
1501
     */
192 efrain 1502
    private function renderFeed($feed_id, $now, $feedHighlighted = 0,  $user_blocked_ids  = [], $abuse_report_comment_ids = [])
1 efrain 1503
    {
283 www 1504
 
1 efrain 1505
        $currentUserPlugin = $this->plugin('currentUserPlugin');
1506
        $currentUser = $currentUserPlugin->getUser();
1507
 
1508
        $currentNetworkPlugin = $this->plugin('currentNetworkPlugin');
1509
        $network = $currentNetworkPlugin->getNetwork();
1510
 
1511
        //$currentCompany = $currentUserPlugin->getCompany();
1512
 
1513
        //$acl = $this->getEvent()->getViewModel()->getVariable('acl');
1514
 
1515
        $userMapper = UserMapper::getInstance($this->adapter);
1516
        $feedMapper = FeedMapper::getInstance($this->adapter);
1517
        $feed = $feedMapper->fetchOneAnyStatus($feed_id);
1518
 
1519
 
1520
 
345 www 1521
        $storage = \LeadersLinked\Library\Storage::getInstance($this->config, $this->adapter);
1 efrain 1522
 
1523
        /*
1524
        $contentReactionMapper = LikeMapper::getInstance($this->adapter);
1525
        $contentReaction = $contentReactionMapper->fetchOneByFeedIdAndUserId($feed->id, $currentUser->id);
1526
        $contentReactions = $contentReactionMapper->fetchCountLikeByFeedId($feed->id);
1527
        */
1528
        $contentReactionMapper = ContentReactionMapper::getInstance($this->adapter);
1529
        $reactions = $contentReactionMapper->fetchCountByFeedId($feed->id);
1530
        $reaction = $contentReactionMapper->fetchOneByFeedIdAndUserId($feed->id, $currentUser->id);
1531
 
1532
 
1533
        $params = [
1534
            'id' => $feed->uuid
1535
        ];
1536
        if ($feed->company_id) {
1537
            $companyMapper = CompanyMapper::getInstance($this->adapter);
1538
            $company = $companyMapper->fetchOne($feed->company_id);
1539
 
1540
            $params['company_id'] = $company->uuid;
1541
        } else {
1542
            $company = null;
1543
        }
1544
        if ($feed->group_id) {
1545
            $groupMapper = GroupMapper::getInstance($this->adapter);
1546
            $group = $groupMapper->fetchOne($feed->group_id);
1547
 
1548
            $params['group_id'] = $group->uuid;
1549
        } else {
1550
            $group = null;
1551
        }
1552
 
1553
 
1554
        $timestamp = time();
1555
 
1556
        list($usec, $sec) = explode(' ', microtime());
1557
        $seed = intval($sec + ((float) $usec * 100000));
1558
        mt_srand($seed, MT_RAND_MT19937);
1559
        $rand =  mt_rand();
1560
 
1561
 
1562
 
1563
        $password  = md5('user-' . $currentUser->uuid . '-feed-' . $feed->uuid . '-timestamp-' . $timestamp . '-rand-' . $rand . '-share-key-' . $currentUser->share_key);
1564
 
1565
 
1566
        $share_params = [
1567
            'type' => 'feed',
1568
            'code' => $feed->uuid,
1569
            'user' => $currentUser->uuid,
1570
            'timestamp' => $timestamp,
1571
            'rand' => $rand,
1572
            'password' => $password,
1573
        ];
1574
 
1575
 
1576
        $share_increment_external_counter_url = $this->url()->fromRoute('share/increment-external-counter', $share_params, ['force_canonical' => true]);
1577
 
1578
 
1579
        $share_external_url = $this->url()->fromRoute('shorter/generate', ['code' => $feed->uuid, 'type' => 'feed'], ['force_canonical' => true]);
1580
 
1581
        $item = [
1582
            'feed_unique' => uniqid(),
1583
            'feed_uuid' => $feed->uuid,
1584
            'feed_my_reaction' => $reaction ? $reaction->reaction : '',
1585
            'feed_delete_url' =>  '',
1586
            'feed_content_type' => $feed->file_type ? $feed->file_type : '',
1587
            'feed_reactions' => $reactions,
232 efrain 1588
            'feed_reactions_url' =>  $this->url()->fromRoute('feed/reactions', ['id' => $feed->uuid], ['force_canonical' => true]),
192 efrain 1589
            'feed_save_reaction_url' =>  $this->url()->fromRoute('feed/save-reaction', ['id' => $feed->uuid], ['force_canonical' => true]),
1 efrain 1590
            'feed_highlighted' => $feed->id == $feedHighlighted ? 1 : 0,
192 efrain 1591
            'feed_abuse_report_url' => $feed->user_id == $currentUser->id ? '' : $this->url()->fromRoute('helpers/abuse-report', ['type' => 'feed', 'id' => $feed->uuid], ['force_canonical' => true]),
1 efrain 1592
            //'is_liked' => $contentReaction ? 1 : 0,
1593
            //'like_url' => $this->url()->fromRoute('post/like', ['id' => $post->uuid]),
1594
            //'unlike_url' => $this->url()->fromRoute('post/unlike', ['id' => $post->uuid]),
1595
 
1596
        ];
1597
 
1598
        $fastSurveyVote =  '';
1599
        if($feed->file_type == Feed::FILE_TYPE_FAST_SURVEY) {
1600
 
1601
            $fastSurveyVoteMapper = FastSurveyVoteMapper::getInstance($this->adapter);
1602
            $fastSurveyVote =  $fastSurveyVoteMapper->fetchOneByFastSurveyIdAndUserId($feed->fast_survey_id, $currentUser->id);
1603
 
1604
 
1605
 
1606
            $item['feed_save_reaction_url'] = '';
1607
            $item['feed_delete_reaction_url'] =  '';
1608
            $item['feed_share_url'] = '';
1609
            $item['feed_share_external_url'] = '';
1610
            $item['feed_increment_external_counter_url'] = '';
1611
 
345 www 1612
            $item['feed_vote_url'] = $fastSurveyVote ? '' : $this->url()->fromRoute('feed/vote',  ['id' => $feed->uuid], ['force_canonical' => true]);
1 efrain 1613
 
1614
        } else {
247 efrain 1615
            $item['feed_save_reaction_url'] =  $this->url()->fromRoute('feed/save-reaction',  $params,  ['force_canonical' => true]);
1616
            $item['feed_delete_reaction_url'] =  $this->url()->fromRoute('feed/delete-reaction',  $params,  ['force_canonical' => true]);
1617
            $item['feed_share_url'] = $this->url()->fromRoute('feed/share',  $params,  ['force_canonical' => true]);
1 efrain 1618
            $item['feed_share_external_url'] = $share_external_url;
1619
            $item['feed_increment_external_counter_url'] = $share_increment_external_counter_url;
1620
            $item['feed_vote_url'] = '';
1621
        }
1622
 
1623
 
1624
        if ($feed->posted_or_shared == Feed::POSTED) {
1625
 
1626
            if ($feed->type == Feed::TYPE_COMPANY) {
283 www 1627
 
1628
 
1 efrain 1629
                $companyMapper = CompanyMapper::getInstance($this->adapter);
1630
                $company = $companyMapper->fetchOne($feed->company_id);
283 www 1631
 
247 efrain 1632
                $item['owner_url'] = $this->url()->fromRoute('company/view', ['id' => $company->uuid],  ['force_canonical' => true]);
345 www 1633
                $item['owner_image'] = $storage->getCompanyImage($company);
1 efrain 1634
                $item['owner_name'] = $company->name;
283 www 1635
 
1 efrain 1636
            } else if ($feed->type == Feed::TYPE_GROUP) {
1637
                $groupMapper = GroupMapper::getInstance($this->adapter);
1638
                $group = $groupMapper->fetchOne($feed->group_id);
283 www 1639
 
1640
 
1 efrain 1641
                $item['owner_url'] = '';
345 www 1642
                $item['owner_image'] = $storage->getGroupImage($group);
1 efrain 1643
                $item['owner_name'] = $group->name;
1644
 
1645
                if ($group->user_id == $currentUser->id) {
247 efrain 1646
                    $item['feed_delete_url'] = $this->url()->fromRoute('feed/delete',  $params,  ['force_canonical' => true]);
1 efrain 1647
                }
1648
            } else {
1649
                $userMapper = UserMapper::getInstance($this->adapter);
1650
                $user = $userMapper->fetchOne($feed->user_id);
283 www 1651
 
1652
 
1 efrain 1653
                $item['owner_url'] = $this->url()->fromRoute('profile/view', ['id' => $user->uuid]);
345 www 1654
                $item['owner_image'] = $storage->getUserImage($user);
1 efrain 1655
                $item['owner_name'] = $user->first_name . ' ' . $user->last_name;
1656
 
1657
                if ($feed->user_id == $currentUser->id) {
247 efrain 1658
                    $item['feed_delete_url'] = $this->url()->fromRoute('feed/delete',  $params,  ['force_canonical' => true]);
1 efrain 1659
                }
1660
            }
1661
        } else {
1662
            if ($feed->user_id == $currentUser->id) {
247 efrain 1663
                $item['feed_delete_url'] = $this->url()->fromRoute('feed/delete',  $params,  ['force_canonical' => true]);
1 efrain 1664
            }
1665
        }
1666
 
1667
        $userMapper = UserMapper::getInstance($this->adapter);
1668
        $user = $userMapper->fetchOne($feed->user_id);
192 efrain 1669
 
1670
 
1 efrain 1671
 
1672
        if ($feed->posted_or_shared == Feed::SHARED) {
283 www 1673
 
192 efrain 1674
            $item['owner_url'] = $this->url()->fromRoute('profile/view', ['id' => $user->uuid],['force_canonical' => true]);
345 www 1675
            $item['owner_image'] = $storage->getUserImage($user);
1 efrain 1676
            $item['owner_name'] = $user->first_name . ' ' . $user->last_name;
1677
        }
1678
 
1679
        if($feed->file_type == Feed::FILE_TYPE_FAST_SURVEY) {
1680
            $fastSurveyMapper = FastSurveyMapper:: getInstance($this->adapter);
1681
            $fastSurvey = $fastSurveyMapper->fetchOne($feed->fast_survey_id);
1682
 
1683
            $owner_description = [
1684
                'question' => $fastSurvey->question,
1685
                'number_of_answers' => $fastSurvey->number_of_answers,
1686
                'answer1' => $fastSurvey->answer1,
1687
                'answer2' => $fastSurvey->answer2,
1688
                'answer3' => $fastSurvey->answer3,
1689
                'answer4' => $fastSurvey->answer4,
1690
                'answer5' => $fastSurvey->answer5,
1691
                'result_type' => $fastSurvey->result_type,
1692
 
1693
            ];
1694
 
1695
            if($fastSurvey->expire_on > $now) {
1696
                $owner_description['active'] = $fastSurveyVote ? 0 : 1;
1697
                $owner_description['time_remaining'] =  Functions::getDateDiff($now, $fastSurvey->expire_on);
1698
 
1699
            } else {
1700
 
1701
 
1702
                $owner_description['active'] = 0;
1703
                $owner_description['time_remaining'] = 0;
1704
            }
1705
 
1706
            if($fastSurvey->result_type == FastSurvey::RESULT_TYPE_PUBLIC && $fastSurveyVote) {
1707
                $owner_description['votes1'] = $fastSurvey->votes1;
1708
                $owner_description['votes2'] = $fastSurvey->votes2;
1709
                $owner_description['votes3'] = $fastSurvey->votes3;
1710
                $owner_description['votes4'] = $fastSurvey->votes4;
1711
                $owner_description['votes5'] = $fastSurvey->votes5;
1712
            }
1713
 
1714
 
1715
 
1716
            $item['owner_description'] =  $owner_description;
1717
        } else {
1718
            $item['owner_description'] = $feed->description;
1719
        }
345 www 1720
 
1721
 
1722
 
1 efrain 1723
        $item['owner_feed_type'] = $feed->type;
1724
 
1725
        $item['owner_shared'] = $feed->total_shared;
1726
        $item['owner_external_shared'] = $feed->total_external_shared;
1727
        $item['owner_comments'] = $feed->total_comments;
1728
 
1729
 
1730
        $item['owner_time_elapse'] = Functions::timeAgo($feed->added_on, $now);
1731
 
345 www 1732
        $path = $storage->getPathFeed();
1733
        if ($feed->file_type == Storage::FILE_TYPE_IMAGE) {
1734
            $item['owner_file_image'] = $storage->getGenericImage($path,  $feed->uuid, $feed->file_name);
1 efrain 1735
        }
345 www 1736
        if ($feed->file_type == Storage::FILE_TYPE_DOCUMENT) {
1737
            $item['owner_file_document'] = $storage->getGenericFile($path,  $feed->uuid, $feed->file_name);
1738
        }
1739
        if ($feed->file_type == Storage::FILE_TYPE_VIDEO) {
283 www 1740
 
345 www 1741
 
1742
 
1743
            $item['owner_file_image_preview'] = $item['owner_file_image'] = $storage->getGenericImage($path,  $feed->uuid, $feed->file_image_preview);
1744
            $item['owner_file_video']  = $storage->getGenericFile($path,  $feed->uuid, $feed->file_name);
1 efrain 1745
        }
1746
 
1747
        if ($feed->posted_or_shared == Feed::SHARED) {
1748
            $sharedFeed = $feedMapper->fetchOneAnyStatus($feed->shared_feed_id);
1749
 
1750
            $item['shared_description'] = $sharedFeed->description;
1751
            $item['shared_time_elapse'] = Functions::timeAgo($sharedFeed->added_on, $now);
1752
 
345 www 1753
            if ($sharedFeed->file_type == Storage::FILE_TYPE_IMAGE) {
1754
                $item['shared_file_image'] = $storage->getGenericImage($path, $sharedFeed->uuid, $sharedFeed->file_name);
1 efrain 1755
            }
345 www 1756
            if ($sharedFeed->file_type == Storage::FILE_TYPE_DOCUMENT) {
1757
                $item['shared_file_document'] = $storage->getGenericFile($path, $sharedFeed->uuid, $sharedFeed->file_name);
1 efrain 1758
            }
345 www 1759
            if ($sharedFeed->file_type == Storage::FILE_TYPE_VIDEO) {
289 www 1760
                $path = $this->storage->getPathFeed();
345 www 1761
                $item['shared_file_image_preview'] = $storage->getGenericImage($path, $sharedFeed->uuid, $sharedFeed->file_image_preview);
1762
                $item['shared_file_video'] = $storage->getGenericFile($path, $sharedFeed->uuid, $sharedFeed->file_name);
283 www 1763
 
1 efrain 1764
            }
1765
 
1766
            $item['shared_content_type'] = $sharedFeed->file_type ? $sharedFeed->file_type : '';
1767
 
1768
            if ($feed->company_id) {
1769
 
1770
                $companyMapper = CompanyMapper::getInstance($this->adapter);
1771
                $sharedCompany = $companyMapper->fetchOne($feed->company_id);
283 www 1772
 
1773
 
1 efrain 1774
                $item['shared_url'] = $this->url()->fromRoute('company/view', ['id' => $sharedCompany->uuid]);
345 www 1775
                $item['shared_image'] = $storage->getCompanyImage($sharedCompany);
1 efrain 1776
                $item['shared_name'] = $sharedCompany->name;
1777
            } else if ($feed->group_id) {
1778
                $groupMapper = GroupMapper::getInstance($this->adapter);
1779
                $sharedGroup = $groupMapper->fetchOne($feed->group_id);
283 www 1780
 
1781
 
1 efrain 1782
                $item['shared_url'] = '';
345 www 1783
                $item['shared_image'] = $storage->getGroupImage($sharedGroup);
1 efrain 1784
                $item['shared_name'] = $sharedGroup->name;
1785
            } else {
1786
                $sharedUser = $userMapper->fetchOne($sharedFeed->user_id);
283 www 1787
 
1 efrain 1788
                $item['shared_url'] = $this->url()->fromRoute('profile/view', ['id' => $sharedUser->uuid]);
289 www 1789
                $item['shared_image'] = $this->storage->getUserImage($sharedUser);
1 efrain 1790
                $item['shared_name'] = $sharedUser->first_name . ' ' . $sharedUser->last_name;
1791
            }
1792
        }
1793
 
1794
 
1795
 
1796
        if($feed->file_type == Feed::FILE_TYPE_FAST_SURVEY) {
1797
            $item['comment_add_url'] = '';
1798
            $item['comments'] = [];
1799
        } else {
1800
 
283 www 1801
            $item['comment_add_url'] = $this->url()->fromRoute('feed/comment', ['id' => $feed->uuid],['force_canonical' => true]);
1 efrain 1802
            $item['comments'] = [];
1803
 
1804
            $commentMapper = CommentMapper::getInstance($this->adapter);
192 efrain 1805
            $records = $commentMapper->fetchAllPublishedByFeedId($feed->id , $user_blocked_ids, $abuse_report_comment_ids);
1 efrain 1806
 
1807
            $companyUserMapper = CompanyUserMapper::getInstance($this->adapter);
1808
            $owner = $companyUserMapper->fetchOwnerByCompanyId($feed->company_id);
1809
 
1810
            $comments = [];
1811
            foreach ($records as $record) {
1812
                $user = $userMapper->fetchOne($record->user_id);
1813
 
1814
 
1815
                if ($user->id == $currentUser->id) {
283 www 1816
                    $link_delete = $this->url()->fromRoute('feed/comment/delete', ['id' => $feed->uuid, 'comment' => $record->uuid],['force_canonical' => true]);
1 efrain 1817
                } else {
1818
                    $link_delete = '';
1819
                }
283 www 1820
 
1 efrain 1821
                array_push($comments , [
1822
                    'unique' => uniqid(),
283 www 1823
                    'user_url' => $this->url()->fromRoute('profile/view', ['id' => $user->uuid],['force_canonical' => true]),
1 efrain 1824
                    'user_name' => $user->first_name . ' ' . $user->last_name,
1825
                    'company' => $owner,
289 www 1826
                    'user_image' => $this->storage->getUserImage($user),
1 efrain 1827
                    'time_elapsed' => Functions::timeAgo($record->added_on, $now),
1828
                    'comment' => $record->comment,
194 efrain 1829
                    'link_abuse_report' => $user->id == $currentUser->id ? '' : $this->url()->fromRoute('helpers/abuse-report', ['type' => 'comment', 'id' => $record->uuid], ['force_canonical' => true]),
1 efrain 1830
                    'link_delete' => $link_delete
1831
                ]);
1832
            }
1833
 
1834
            $item['comments'] = $comments;
1835
        }
1836
 
1837
 
1838
        return $item;
1839
    }
1840
 
1841
    /**
1842
     *
1843
     * @param int $comment_id
1844
     * @return array
1845
     */
1846
    private function renderComment($comment_id, $now)
1847
    {
192 efrain 1848
        $currentUserPlugin = $this->plugin('currentUserPlugin');
1849
        $currentUser = $currentUserPlugin->getUser();
1850
 
1 efrain 1851
        $item = [];
1852
 
1853
        $commentMapper = CommentMapper::getInstance($this->adapter);
1854
        $record = $commentMapper->fetchOne($comment_id);
1855
 
1856
        $feedMapper = FeedMapper::getInstance($this->adapter);
1857
        $feed = $feedMapper->fetchOne($record->feed_id);
1858
 
1859
        if ($record) {
289 www 1860
 
283 www 1861
 
1 efrain 1862
            $userMapper = UserMapper::getInstance($this->adapter);
1863
 
1864
            $user = $userMapper->fetchOne($record->user_id);
1865
 
1866
            $item['unique'] = uniqid();
289 www 1867
            $item['user_image'] = $this->storage->getUserImage($user);
1 efrain 1868
            $item['user_url'] = $this->url()->fromRoute('profile', ['id' => $user->uuid]);
1869
            $item['user_name'] = $user->first_name . ' ' . $user->last_name;
1870
            $item['time_elapsed'] = Functions::timeAgo($record->added_on, $now);
1871
            $item['comment'] = $record->comment;
192 efrain 1872
            $item['link_abuse_report'] = $user->id == $currentUser ? '' : $this->url()->fromRoute('helpers/abuse-report', ['type' => 'comment', 'id' => $record->uuid], ['force_canonical' => true]);
1 efrain 1873
            $item['link_delete'] = $this->url()->fromRoute('feed/comment/delete', ['id' => $feed->uuid, 'comment' => $record->uuid]);
1874
        }
1875
        return $item;
1876
    }
1877
 
1878
    /**
1879
     *
1880
     * @param string $path
1881
     * @return boolean
1882
     */
1883
    private function deletePath($path)
1884
    {
1885
        try {
1886
            if (is_dir($path)) {
1887
                if ($dh = opendir($path)) {
1888
                    while (($file = readdir($dh)) !== false) {
1889
                        if ($file == '.' || $file == '..') {
1890
                            continue;
1891
                        }
1892
                        unlink($path . DIRECTORY_SEPARATOR . $file);
1893
                    }
1894
                    closedir($dh);
1895
                }
1896
 
1897
                rmdir($path);
1898
            }
1899
            return true;
1900
        } catch (\Throwable $e) {
1901
            error_log($e->getTraceAsString());
1902
            return false;
1903
        }
1904
    }
1905
 
1906
 
1907
    /**
1908
     *
1909
     * @param Feed $feed
1910
     * @return array
1911
     */
1912
    private function deleteFeed($feed)
1913
    {
1914
        $feedMapper = FeedMapper::getInstance($this->adapter);
1915
        $feed->status = Feed::STATUS_DELETED;
1916
        if ($feedMapper->update($feed)) {
1917
            $response = [
1918
                'success' => true,
1919
                'data' => 'LABEL_FEED_WAS_DELETED'
1920
            ];
1921
        } else {
1922
            $response = [
1923
                'success' => false,
1924
                'data' => $feedMapper->getError()
1925
            ];
1926
        }
1927
 
1928
 
1929
        /*$commentMapper = CommentMapper::getInstance($this->adapter);
1930
        if($commentMapper->deleteAllByFeedId($feed->id)) {
1931
            if($feedMapper->delete($feed->id)) {
1932
                $target_path = $this->config['leaderslinked.fullpath.feed'] . DIRECTORY_SEPARATOR . $feed->id;
1933
                if(file_exists($target_path)) {
1934
                    $this->deletePath($target_path);
1935
                }
1936
 
1937
                $response = [
1938
                    'success' => true,
1939
                    'data' => 'LABEL_FEED_WAS_DELETED'
1940
                ];
1941
 
1942
            } else {
1943
                $response = [
1944
                    'success' => false,
1945
                    'data' => $feedMapper->getError()
1946
                ];
1947
            }
1948
        } else {
1949
            $response = [
1950
                'success' => false,
1951
                'data' => $commentMapper->getError()
1952
            ];
1953
 
1954
        }*/
1955
 
1956
        return $response;
1957
    }
1958
 
1959
 
1960
    public function voteAction()
1961
    {
1962
        $id = $this->params()->fromRoute('id');
1963
 
1964
 
1965
        $request = $this->getRequest();
1966
        if ($request->isPost()) {
1967
 
1968
 
1969
 
1970
            $currentUserPlugin = $this->plugin('currentUserPlugin');
1971
            $currentUser = $currentUserPlugin->getUser();
1972
 
1973
 
1974
            $feedMapper = FeedMapper::getInstance($this->adapter);
1975
            $feed = $feedMapper->fetchOneByUuidAndNetworkId($id, $currentUser->network_id);
1976
            if (!$feed) {
1977
                $response = [
1978
                    'success' => false,
1979
                    'data' => 'ERROR_POST_NOT_FOUND'
1980
                ];
1981
                return new JsonModel($response);
1982
            }
1983
 
1984
 
1985
            if($feed->file_type != Feed::FILE_TYPE_FAST_SURVEY) {
1986
                $response = [
1987
                    'success' => false,
1988
                    'data' => 'ERROR_FAST_SURVEY_FEED_IS_NOT_FAST_SURVEY'
1989
                ];
1990
                return new JsonModel($response);
1991
            }
1992
 
1993
            $fastSurveyMapper = FastSurveyMapper::getInstance($this->adapter);
1994
            $fastSurvey = $fastSurveyMapper->fetchOne($feed->fast_survey_id);
1995
            if(!$fastSurvey) {
1996
                $response = [
1997
                    'success' => false,
1998
                    'data' => 'ERROR_FAST_SURVEY_NOT_FOUND'
1999
                ];
2000
                return new JsonModel($response);
2001
            }
2002
 
2003
            $now = $fastSurveyMapper->getDatebaseNow();
2004
            if($fastSurvey->expire_on <= $now) {
2005
                $response = [
2006
                    'success' => false,
2007
                    'data' => 'ERROR_FAST_SURVEY_IS_EXPIRED'
2008
                ];
2009
                return new JsonModel($response);
2010
            }
2011
 
2012
 
2013
            if($fastSurvey->privacy == FastSurvey::PRIVACY_COMPANY) {
2014
 
2015
                $companyUserMapper = CompanyUserMapper::getInstance($this->adapter);
2016
                $companyUser = $companyUserMapper->fetchOneByCompanyIdAndUserId($fastSurvey->company_id, $currentUser->id);
2017
                if(!$companyUser || !in_array($companyUser->status, [CompanyUser::STATUS_ACCEPTED, CompanyUser::STATUS_ADMIN_WILL_ADD])) {
2018
                    $response = [
2019
                        'success' => false,
2020
                        'data' => 'ERROR_FAST_SURVEY_UNAUTHORIZED'
2021
                    ];
2022
                    return new JsonModel($response);
2023
                }
2024
 
2025
            }
2026
 
2027
 
2028
 
2029
            $vote = intval($this->params()->fromPost('vote', 0), 10);
2030
            if($vote < 1 || $vote > 5 || $vote > $fastSurvey->number_of_answers) {
2031
                $response = [
2032
                    'success' => false,
2033
                    'data' => 'ERROR_FAST_SURVEY_VOTE_IS_INVALID'
2034
                ];
2035
                return new JsonModel($response);
2036
            }
2037
 
2038
            $fastSurveyVoteMapper = FastSurveyVoteMapper::getInstance($this->adapter);
2039
            $fastSurveyVote = $fastSurveyVoteMapper->fetchOneByFastSurveyIdAndUserId($fastSurvey->id, $currentUser->id);
2040
            if($fastSurveyVote) {
2041
                $response = [
2042
                    'success' => false,
2043
                    'data' => 'ERROR_FAST_SURVEY_VOTE_IS_ALREADY_FOUND'
2044
                ];
2045
                return new JsonModel($response);
2046
            }
2047
 
2048
            $fastSurveyVote = new FastSurveyVote();
2049
            $fastSurveyVote->fast_survey_id = $fastSurvey->id;
2050
            $fastSurveyVote->user_id = $currentUser->id;
2051
            $fastSurveyVote->vote = $vote;
2052
 
2053
 
2054
            if ($fastSurveyVoteMapper->insert($fastSurveyVote)) {
2055
 
2056
                $response = [
2057
                    'success'   => true,
2058
                    'data'   => $this->renderFeed($feed->id, $now)
2059
                ];
2060
            } else {
2061
                $response = [
2062
                    'success' => false,
2063
                    'data' => $fastSurveyVoteMapper->getError()
2064
                ];
2065
            }
2066
            return new JsonModel($response);
2067
        }
2068
 
2069
        $response = [
2070
            'success' => false,
2071
            'data' => 'ERROR_METHOD_NOT_ALLOWED'
2072
        ];
2073
        return new JsonModel($response);
2074
    }
2075
}