WebSVN – LeadersLinked - Antes de SPA – Diff – /module/LeadersLinked/src/Controller/FeedController.php

 use LeadersLinked\Model\ContentReaction;
 use LeadersLinked\Form\Feed\CommentForm;
 use LeadersLinked\Model\Comment;
 use LeadersLinked\Form\Feed\CreateGroupCompanyForm;
 use LeadersLinked\Model\CompanyUser;
+use LeadersLinked\Model\FastSurvey;
 use LeadersLinked\Model\VideoConvert;
 use LeadersLinked\Mapper\VideoConvertMapper;
 use LeadersLinked\Mapper\CompanyMapper;
 use LeadersLinked\Model\Company;
 use LeadersLinked\Model\Group;
 use LeadersLinked\Mapper\NotificationMapper;
 use LeadersLinked\Mapper\UserNotificationSettingMapper;
 use LeadersLinked\Mapper\EmailTemplateMapper;
 use LeadersLinked\Model\EmailTemplate;
 use LeadersLinked\Library\QueueEmail;
-use LeadersLinked\Mapper\UtilMapper;
+use LeadersLinked\Mapper\FastSurveyMapper;
+use LeadersLinked\Mapper\FastSurveyVoteMapper;
+use LeadersLinked\Model\FastSurveyVote;
 class FeedController extends AbstractActionController
+    {
         $id = $this->params()->fromRoute('id');
         $request = $this->getRequest();
-        if ($request->isPost()) {
         if ($request->isPost()) {
+            $feedMapper = FeedMapper::getInstance($this->adapter);
+            $now = $feedMapper->getDatebaseNow();
             $feedMapper = FeedMapper::getInstance($this->adapter);
+            $feed = $feedMapper->fetchOneByUuid($id);
             $feed = $feedMapper->fetchOneByUuid($id);
             if (!$feed) {
                 $response = [
                     'success' => false,
                     'data' => 'ERROR_POST_NOT_FOUND'
             $dataPost = $request->getPost()->toArray();
             $form = new CommentForm();
             $form->setData($dataPost);
-            if ($form->isValid()) {
-                $utilMapper = UtilMapper::getInstance($this->adapter);
-                $now = $utilMapper->getDatebaseNow();
             if ($form->isValid()) {
                 $currentUserPlugin = $this->plugin('currentUserPlugin');
                 $currentUser = $currentUserPlugin->getUser();
         return new JsonModel($response);
+    }
     public function postOrShareFeed($dataPost)
-    {
-        $utilMapper = UtilMapper::getInstance($this->adapter);
+    {
         $now = $utilMapper->getDatebaseNow();
         $currentUserPlugin = $this->plugin('currentUserPlugin');
             $company = null;
             $group = null;
             if ($companyId) {
+                $companyMapper = CompanyMapper::getInstance($this->adapter);
+                $now = $companyMapper->getDatebaseNow();
                 $companyMapper = CompanyMapper::getInstance($this->adapter);
                 $company = $companyMapper->fetchOneByUuidAndNetworkId($companyId, $currentUser->network_id);
+                }
+            }
             if ($groupId) {
+                $groupMapper = GroupMapper::getInstance($this->adapter);
+                $now = $groupMapper->getDatebaseNow();
                 $groupMapper = GroupMapper::getInstance($this->adapter);
                 $group = $groupMapper->fetchOneByUuidAndNetworkId($groupId, $currentUser->network_id);
                 if (!$group) {
                     'data'      => 'ERROR_SUPPLY_VALID_SHARING_STATUS'
                 ];
+            }
             $feed->posted_or_shared = $posted_or_shared;
             $feedMapper = FeedMapper::getInstance($this->adapter);
+            $now = $feedMapper->getDatebaseNow();
             $shared_with = isset($dataPost['shared_with']) ? $dataPost['shared_with'] : Feed::SHARE_WITH_PUBLIC;
             if ($shared_with != Feed::SHARE_WITH_PUBLIC && $shared_with != Feed::SHARE_WITH_CONNECTIONS) {
                 return [
         return new JsonModel($response);
     }*/
     public function timelineAction()
-    {
-        $utilMapper = UtilMapper::getInstance($this->adapter);
+    {
         $now = $utilMapper->getDatebaseNow();
+        if ($feedUuid) {
             $feedMapper = FeedMapper::getInstance($this->adapter);
-        if ($feedUuid) {
+            $now = $feedMapper->getDatebaseNow();
             $feedMapper = FeedMapper::getInstance($this->adapter);
             $feed = $feedMapper->fetchOneByUuidAndNetworkIdAnyStatus($feedUuid, $currentUser->network_id);
+        $request = $this->getRequest();
+        if ($request->isGet()) {
+            $exclude_feed_ids = [];
+            $queryMapper = QueryMapper::getInstance($this->adapter);
+            $selectNotUserCompany = $queryMapper->getSql()->select();
+            $selectNotUserCompany->columns(['company_id']);
+            $selectNotUserCompany->from(['cu' => CompanyUserMapper::_TABLE]);
+            $selectNotUserCompany->where->equalTo('user_id', $currentUser->id);
+            $selectNotUserCompany->where->in('status', [CompanyUser::STATUS_ACCEPTED, CompanyUser::STATUS_ADMIN_WILL_ADD]);
+            $select = $queryMapper->getSql()->select();
+            $select->columns(['id']);
+            $select->from(['f' => FeedMapper::_TABLE]);
+            $select->join(['fs' => FastSurveyMapper::_TABLE], 'fs.id = f.fast_survey_id', []);
+            $select->where->equalTo('f.file_type', Feed::FILE_TYPE_FAST_SURVEY);
+            $select->where->equalTo('f.network_id', $currentUser->network_id);
+            $select->where->equalTo('f.status', Feed::STATUS_PUBLISHED);
+            $select->where->equalTo('fs.privacy', FastSurvey::PRIVACY_COMPANY);
+            $select->where->notIn('fs.company_id', $selectNotUserCompany);
+            $records = $queryMapper->fetchAll($select);
+            foreach($records as $record)
+            {
                 array_push($exclude_feed_ids, $record['id']);
         $request = $this->getRequest();
         if ($request->isGet()) {
+            $page = (int) $this->params()->fromQuery('page');
             if ($type == 'user') {
-            $page = (int) $this->params()->fromQuery('page');
+                $connectionMapper = ConnectionMapper::getInstance($this->adapter);
-            if ($type == 'user') {
+                $now = $connectionMapper->getDatebaseNow();
                 $connectionMapper = ConnectionMapper::getInstance($this->adapter);
                 $records = $connectionMapper->fetchAllConnectionsByUser($id);
                     ->OR->NEST->and->equalTo('type', Feed::TYPE_UPDATE)->and->equalTo('shared_with', Feed::SHARE_WITH_PUBLIC)->UNNEST
                     ->OR->NEST->in('user_id', $connectionIds)->and->equalTo('type', Feed::TYPE_UPDATE)->and->equalTo('shared_with', Feed::SHARE_WITH_CONNECTIONS)->UNNEST
                     ->OR->NEST->or->in('company_id', $companyIds)->and->equalTo('type', Feed::TYPE_COMPANY)->UNNEST
                     ->OR->NEST->or->in('group_id', $groupIds)->and->equalTo('type', Feed::TYPE_GROUP)->UNNEST
                     ->UNNEST;
+                if($exclude_feed_ids) {
+                    $select->where->notIn('id', $exclude_feed_ids);
+                }
                 $select->order('added_on desc');
+            }
             if ($type == 'company') {
                 $companyMapper = CompanyMapper::getInstance($this->adapter);
+                $now = $companyMapper->getDatebaseNow();
                 $company = $companyMapper->fetchOneByUuidAndNetworkId($id, $currentUser->network_id);
                 if (!$company || $company->status != Company::STATUS_ACTIVE) {
                     $id = 0;
                         } else {
                             $id = $company->id;
+                        }
+                    }
+                }
                 $queryMapper = QueryMapper::getInstance($this->adapter);
                 $select = $queryMapper->getSql()->select(FeedMapper::_TABLE);
                 $select->columns(['id']);
                 $select->where->equalTo('network_id', $currentUser->network_id);
                 $select->where->equalTo('status', Feed::STATUS_PUBLISHED);
                 $select->where->equalTo('company_id', $id);
+                $select->where->and->equalTo('type', Feed::TYPE_COMPANY);
+                if($exclude_feed_ids) {
+                    $select->where->notIn('id', $exclude_feed_ids);
+                }
                 $select->where->and->equalTo('type', Feed::TYPE_COMPANY);
                 $select->order('added_on desc');
+            }
             if ($type == 'group') {
+                $groupMapper = GroupMapper::getInstance($this->adapter);
+                $now = $groupMapper->getDatebaseNow();
                 $groupMapper = GroupMapper::getInstance($this->adapter);
                 $group = $groupMapper->fetchOneByUuidAndNetworkId($id, $currentUser->network_id);
                 $select = $queryMapper->getSql()->select(FeedMapper::_TABLE);
                 $select->columns(['id']);
                 $select->where->equalTo('network_id', $currentUser->network_id);
                 $select->where->equalTo('status', Feed::STATUS_PUBLISHED);
                 $select->where->equalTo('group_id', $id);
-                $select->where->and->equalTo('type', Feed::TYPE_GROUP);
+                $select->where->nest()->equalTo('type', Feed::TYPE_GROUP)
-                $select->where->or->equalTo('type', Feed::TYPE_UPDATE);
+                ->or->equalTo('type', Feed::TYPE_UPDATE)->unnest();
+                if($exclude_feed_ids) {
+                    $select->where->notIn('id', $exclude_feed_ids);
+                }
                 $select->order('added_on desc');
+            }
             $dbSelect = new DbSelect($select, $this->adapter);
         $item = [
             'feed_unique' => uniqid(),
             'feed_uuid' => $feed->uuid,
-            'feed_my_reaction' => $reaction ? $reaction->reaction : '',
-            'feed_save_reaction_recommended_url' => $feed_save_reaction_recommended,
-            'feed_save_reaction_support_url' => $feed_save_reaction_support,
-            'feed_save_reaction_love_url' => $feed_save_reaction_love,
-            'feed_save_reaction_interest_url' => $feed_save_reaction_interest,
-            'feed_save_reaction_fun_url' => $feed_save_reaction_fun,
-            'feed_delete_reaction_url' =>  $this->url()->fromRoute('feed/delete-reaction',  $params),
-            'feed_share_url' => $this->url()->fromRoute('feed/share',  $params),
-            'feed_share_external_url' => $share_external_url,
-            'feed_increment_external_counter_url' => $share_increment_external_counter_url,
+            'feed_my_reaction' => $reaction ? $reaction->reaction : '',
             'feed_delete_url' =>  '',
             'feed_content_type' => $feed->file_type ? $feed->file_type : '',
             'feed_reactions' =>  $reactions,
             'feed_highlighted' => $feed->id == $feedHighlighted ? 1 : 0,
             //'is_liked' => $contentReaction ? 1 : 0,
             //'like_url' => $this->url()->fromRoute('post/like', ['id' => $post->uuid]),
             //'unlike_url' => $this->url()->fromRoute('post/unlike', ['id' => $post->uuid]),
+        ];
+        $fastSurveyVote =  '';
+        if($feed->file_type == Feed::FILE_TYPE_FAST_SURVEY) {
+            $fastSurveyVoteMapper = FastSurveyVoteMapper::getInstance($this->adapter);
+            $fastSurveyVote =  $fastSurveyVoteMapper->fetchOneByFastSurveyIdAndUserId($feed->fast_survey_id, $currentUser->id);
+            $item['feed_save_reaction_recommended_url'] = '';
+            $item['feed_save_reaction_support_url'] = '';
+            $item['feed_save_reaction_love_url'] = '';
+            $item['feed_save_reaction_interest_url'] = '';
+            $item['feed_save_reaction_fun_url'] = '';
+            $item['feed_delete_reaction_url'] =  '';
+            $item['feed_share_url'] = '';
+            $item['feed_share_external_url'] = '';
+            $item['feed_increment_external_counter_url'] = '';
+            $item['feed_vote_url'] = $fastSurveyVote ? '' : $this->url()->fromRoute('feed/vote',  ['id' => $feed->uuid]);
+        } else {
+            $item['feed_save_reaction_recommended_url'] = $feed_save_reaction_recommended;
+            $item['feed_save_reaction_support_url'] = $feed_save_reaction_support;
+            $item['feed_save_reaction_love_url'] = $feed_save_reaction_love;
+            $item['feed_save_reaction_interest_url'] = $feed_save_reaction_interest;
+            $item['feed_save_reaction_fun_url'] = $feed_save_reaction_fun;
+            $item['feed_delete_reaction_url'] =  $this->url()->fromRoute('feed/delete-reaction',  $params);
+            $item['feed_share_url'] = $this->url()->fromRoute('feed/share',  $params);
+            $item['feed_share_external_url'] = $share_external_url;
+            $item['feed_increment_external_counter_url'] = $share_increment_external_counter_url;
+            $item['feed_vote_url'] = '';
+        }
         ];
             $item['owner_url'] = $this->url()->fromRoute('profile/view', ['id' => $user->uuid]);
             $item['owner_image'] = $this->url()->fromRoute('storage', ['code' => $user->uuid, 'type' => 'user', 'filename' => $user->image]);
             $item['owner_name'] = $user->first_name . ' ' . $user->last_name;
+        }
+        if($feed->file_type == Feed::FILE_TYPE_FAST_SURVEY) {
+            $fastSurveyMapper = FastSurveyMapper:: getInstance($this->adapter);
+            $fastSurvey = $fastSurveyMapper->fetchOne($feed->fast_survey_id);
+            $owner_description = [
+                'question' => $fastSurvey->question,
+                'number_of_answers' => $fastSurvey->number_of_answers,
+                'answer1' => $fastSurvey->answer1,
+                'answer2' => $fastSurvey->answer2,
+                'answer3' => $fastSurvey->answer3,
+                'answer4' => $fastSurvey->answer4,
+                'answer5' => $fastSurvey->answer5,
+                'result_type' => $fastSurvey->result_type,
+            ];
+            if($fastSurvey->expire_on > $now) {
+                $owner_description['active'] = $fastSurveyVote ? 0 : 1;
+                $owner_description['time_remaining'] =  Functions::getDateDiff($now, $fastSurvey->expire_on);
+            } else {
+                if($fastSurvey->result_type == FastSurvey::RESULT_TYPE_PUBLIC) {
+                    $owner_description['votes1'] = $fastSurvey->votes1;
+                    $owner_description['votes2'] = $fastSurvey->votes2;
+                    $owner_description['votes3'] = $fastSurvey->votes3;
+                    $owner_description['votes4'] = $fastSurvey->votes4;
+                    $owner_description['votes5'] = $fastSurvey->votes5;
+                }
+                $owner_description['active'] = 0;
+                $owner_description['time_remaining'] = 0;
+            }
+            $item['owner_description'] =  $owner_description;
+        } else {
+            $item['owner_description'] = $feed->description;
         $item['owner_description'] = $feed->description;
         $item['owner_feed_type'] = $feed->type;
         $item['owner_shared'] = $feed->total_shared;
+            }
+        }
+        $companyMapper = CompanyMapper::getInstance($this->adapter);
+        if($feed->file_type == Feed::FILE_TYPE_FAST_SURVEY) {
+            $item['comment_add_url'] = '';
+            $item['comments'] = [];
-        $companyMapper = CompanyMapper::getInstance($this->adapter);
+        } else {
-        $companies = [];
+            $companies = [];
-        $commentMapper = CommentMapper::getInstance($this->adapter);
+            $commentMapper = CommentMapper::getInstance($this->adapter);
-        $records = $commentMapper->fetchAllPublishedByFeedId($feed->id);
+            $records = $commentMapper->fetchAllPublishedByFeedId($feed->id);
-        $companyUserMapper = CompanyUserMapper::getInstance($this->adapter);
+            $companyUserMapper = CompanyUserMapper::getInstance($this->adapter);
-        $owner = $companyUserMapper->fetchOwnerByCompanyId($feed->company_id);
+            $owner = $companyUserMapper->fetchOwnerByCompanyId($feed->company_id);
-        $comments = [];
+            $comments = [];
-        foreach ($records as $record) {
+            foreach ($records as $record) {
-            $user = $userMapper->fetchOne($record->user_id);
+                $user = $userMapper->fetchOne($record->user_id);
-            $company = $companyMapper->fetchOne($feed->company_id);
+                $company = $companyMapper->fetchOne($feed->company_id);
-            if ($record->user_id == $currentUser->id) {
+                if ($record->user_id == $currentUser->id) {
-                $link_delete = $this->url()->fromRoute('feed/comment/delete', ['id' => $feed->uuid, 'comment' => $record->uuid]);
+                    $link_delete = $this->url()->fromRoute('feed/comment/delete', ['id' => $feed->uuid, 'comment' => $record->uuid]);
-                array_push($comments, [
+                    array_push($comments, [
-                    'unique' => uniqid(),
+                        'unique' => uniqid(),
-                    'user_url' => $this->url()->fromRoute('profile/view', ['id' => $user->uuid]),
+                        'user_url' => $this->url()->fromRoute('profile/view', ['id' => $user->uuid]),
-                    'user_name' => $user->first_name . ' ' . $user->last_name,
+                        'user_name' => $user->first_name . ' ' . $user->last_name,
-                    'company' => $owner,
+                        'company' => $owner,
-                    'user_image' => $this->url()->fromRoute('storage', ['type' => 'user',  'code' => $user->uuid, 'filename' =>  $user->image]),
+                        'user_image' => $this->url()->fromRoute('storage', ['type' => 'user',  'code' => $user->uuid, 'filename' =>  $user->image]),
-                    'time_elapsed' => Functions::timeAgo($record->added_on, $now),
+                        'time_elapsed' => Functions::timeAgo($record->added_on, $now),
-                    'comment' => $record->comment,
+                        'comment' => $record->comment,
-                    'link_delete' => $link_delete
+                        'link_delete' => $link_delete
-                ]);
+                    ]);
-            } else {
+                } else {
-                array_push($comments, [
+                    array_push($comments, [
-                    'unique' => uniqid(),
+                        'unique' => uniqid(),
-                    'user_url' => $this->url()->fromRoute('profile/view', ['id' => $user->uuid]),
+                        'user_url' => $this->url()->fromRoute('profile/view', ['id' => $user->uuid]),
-                    'user_name' => $user->first_name . ' ' . $user->last_name,
+                        'user_name' => $user->first_name . ' ' . $user->last_name,
-                    'user_image' => $this->url()->fromRoute('storage', ['type' => 'company',  'code' => $company->uuid, 'filename' =>  $company->image]),
+                        'user_image' => $this->url()->fromRoute('storage', ['type' => 'company',  'code' => $company->uuid, 'filename' =>  $company->image]),
-                    'time_elapsed' => Functions::timeAgo($record->added_on, $now),
+                        'time_elapsed' => Functions::timeAgo($record->added_on, $now),
-                    'comment' => $record->comment,
+                        'comment' => $record->comment,
-                    //'link_delete' => $link_delete
+                        //'link_delete' => $link_delete
+                    ]);
-                ]);
+                    $link_delete = '';
+                }
+            }
-                $link_delete = '';
+        }
-            }
-        }
+        echo '<pre>';
+        print_r($feed);
+        print_r($item);
-        $item['comment_add_url'] = $this->url()->fromRoute('feed/comment', ['id' => $feed->uuid]);
+        echo '</pre>';
-        $item['comments'] = $comments;
+        exit;
         }*/
+        return $response;
+    }
+    public function voteAction()
+    {
+        $id = $this->params()->fromRoute('id');
+        $request = $this->getRequest();
+        if ($request->isPost()) {
+            $currentUserPlugin = $this->plugin('currentUserPlugin');
+            $currentUser = $currentUserPlugin->getUser();
+            $feedMapper = FeedMapper::getInstance($this->adapter);
+            $feed = $feedMapper->fetchOneByUuidAndNetworkId($id, $currentUser->network_id);
+            if (!$feed) {
+                $response = [
+                    'success' => false,
+                    'data' => 'ERROR_POST_NOT_FOUND'
+                ];
+                return new JsonModel($response);
+            }
+            if($feed->file_type != Feed::FILE_TYPE_FAST_SURVEY) {
+                $response = [
+                    'success' => false,
+                    'data' => 'ERROR_FAST_SURVEY_FEED_IS_NOT_FAST_SURVEY'
+                ];
+                return new JsonModel($response);
+            }
+            $fastSurveyMapper = FastSurveyMapper::getInstance($this->adapter);
+            $fastSurvey = $fastSurveyMapper->fetchOne($feed->fast_survey_id);
+            if(!$fastSurvey) {
+                $response = [
+                    'success' => false,
+                    'data' => 'ERROR_FAST_SURVEY_NOT_FOUND'
+                ];
+                return new JsonModel($response);
+            }
+            $now = $fastSurveyMapper->getDatebaseNow();
+            if($fastSurvey->expire_on <= $now) {
+                $response = [
+                    'success' => false,
+                    'data' => 'ERROR_FAST_SURVEY_IS_EXPIRED'
+                ];
+                return new JsonModel($response);
+            }
+            if($fastSurvey->privacy == FastSurvey::PRIVACY_COMPANY) {
+                $companyUserMapper = CompanyUserMapper::getInstance($this->adapter);
+                $companyUser = $companyUserMapper->fetchOneByCompanyIdAndUserId($fastSurvey->company_id, $currentUser->id);
+                if(!$companyUser || !in_array($companyUser->status, [CompanyUser::STATUS_ACCEPTED, CompanyUser::STATUS_ADMIN_WILL_ADD])) {
+                    $response = [
+                        'success' => false,
+                        'data' => 'ERROR_FAST_SURVEY_UNAUTHORIZED'
+                    ];
+                    return new JsonModel($response);
+                }
+            }
+            $vote = intval($this->params()->fromPost('vote', 0), 10);
+            if($vote < 1 || $vote > 5 || $vote > $fastSurvey->number_of_answers) {
+                $response = [
+                    'success' => false,
+                    'data' => 'ERROR_FAST_SURVEY_VOTE_IS_INVALID'
+                ];
+                return new JsonModel($response);
+            }
+            $fastSurveyVoteMapper = FastSurveyVoteMapper::getInstance($this->adapter);
+            $fastSurveyVote = $fastSurveyVoteMapper->fetchOneByFastSurveyIdAndUserId($fastSurvey->id, $currentUser->id);
+            if($fastSurveyVote) {
+                $response = [
+                    'success' => false,
+                    'data' => 'ERROR_FAST_SURVEY_VOTE_IS_ALREADY_FOUND'
+                ];
+                return new JsonModel($response);
+            }
+            $fastSurveyVote = new FastSurveyVote();
+            $fastSurveyVote->fast_survey_id = $fastSurvey->id;
+            $fastSurveyVote->user_id = $currentUser->id;
+            $fastSurveyVote->vote = $vote;
+            if ($fastSurveyVoteMapper->insert($fastSurveyVote)) {
+                return [
+                    'success'   => true,
+                    'data'   => $this->renderFeed($feed->id, $now)
+                ];
+            } else {
+                $response = [
+                    'success' => false,
+                    'data' => $fastSurveyVoteMapper->getError()
+                ];
+            }
+            return new JsonModel($response);
+        }
+        $response = [
+            'success' => false,
+            'data' => 'ERROR_METHOD_NOT_ALLOWED'
+        ];
-        return $response;
+        return new JsonModel($response);

Proyectos de Subversion LeadersLinked - Antes de SPA

(root)/module/LeadersLinked/src/Controller/FeedController.php – Rev 6240 → 6388