Rev 16769 | AutorÃa | Ultima modificación | Ver Log |
<?php
declare(strict_types=1);
namespace LeadersLinked\Controller;
use Laminas\Authentication\AuthenticationService;
use Laminas\Authentication\Result as AuthResult;
use Laminas\Db\Adapter\AdapterInterface;
use Laminas\Mvc\Controller\AbstractActionController;
use Laminas\Mvc\I18n\Translator;
use Laminas\Log\LoggerInterface;
use Laminas\View\Model\ViewModel;
use Laminas\View\Model\JsonModel;
use LeadersLinked\Model\HighPerformanceTeamsGroupsMembers;
use LeadersLinked\Hydrator\ObjectPropertyHydrator;
use LeadersLinked\Form\HighPerformanceTeamsGroupsMembersForm;
use LeadersLinked\Form\HighPerformanceTeamsGroupsMembersTypeForm;
use LeadersLinked\Library\Functions;
use LeadersLinked\Mapper\UserMapper;
use LeadersLinked\Mapper\HighPerformanceTeamsGroupsMembersMapper;
use LeadersLinked\Mapper\CompanyMapper;
use LeadersLinked\Mapper\CompanyUserMapper;
use LeadersLinked\Model\ChatGroupUser;
use LeadersLinked\Mapper\ConnectionMapper;
use LeadersLinked\Model\ChatGroup;
use LeadersLinked\Mapper\ChatGroupMapper;
use LeadersLinked\Mapper\ChatGroupUserMapper;
use LeadersLinked\Mapper\ChatGroupUserMessageMapper;
use LeadersLinked\Mapper\ChatGroupMessageMapper;
use LeadersLinked\Mapper\HighPerformanceTeamsGroupsMapper;
class HighPerformanceTeamsGroupsMembersController extends AbstractActionController
{
/**
*
* @var \Laminas\Db\Adapter\AdapterInterface
*/
private $adapter;
/**
*
* @var \LeadersLinked\Cache\CacheInterface
*/
private $cache;
/**
*
* @var \Laminas\Log\LoggerInterface
*/
private $logger;
/**
*
* @var array
*/
private $config;
/**
*
* @var \Laminas\Mvc\I18n\Translator
*/
private $translator;
/**
*
* @param \Laminas\Db\Adapter\AdapterInterface $adapter
* @param \LeadersLinked\Cache\CacheInterface $cache
* @param \Laminas\Log\LoggerInterface LoggerInterface $logger
* @param array $config
* @param \Laminas\Mvc\I18n\Translator $translator
*/
public function __construct($adapter, $cache, $logger, $config, $translator)
{
$this->adapter = $adapter;
$this->cache = $cache;
$this->logger = $logger;
$this->config = $config;
$this->translator = $translator;
}
public function indexAction()
{
$currentUserPlugin = $this->plugin('currentUserPlugin');
$currentUser = $currentUserPlugin->getUser();
$currentCompany = $currentUserPlugin->getCompany();
$group_uuid= $this->params()->fromRoute('group_id');
$request = $this->getRequest();
$acl = $this->getEvent()->getViewModel()->getVariable('acl');
$allowInvite = $acl->isAllowed($currentUser->usertype_id,'high-performance-teams/groups/view/members/invite');
$allowDelete = $acl->isAllowed($currentUser->usertype_id,'high-performance-teams/groups/view/members/delete');
$allowEdit = $acl->isAllowed($currentUser->usertype_id,'high-performance-teams/groups/view/members/edit');
$highPerformanceTeamsGroupsMapper = HighPerformanceTeamsGroupsMapper::getInstance($this->adapter);
$highPerformanceTeamsGroups = $highPerformanceTeamsGroupsMapper->fetchOneByUuid($group_uuid);
if (!$highPerformanceTeamsGroups) {
$data = [
'success' => false,
'data' => 'ERROR_RECORD_NOT_FOUND'
];
return new JsonModel($data);
}
$highPerformanceTeamsGroupsMembersMapper = HighPerformanceTeamsGroupsMembersMapper::getInstance($this->adapter);
$highPerformanceTeamsGroupsMembers = $highPerformanceTeamsGroupsMembersMapper->fetchAllInnerJoinUser($highPerformanceTeamsGroups->id,UserMapper::_TABLE);
if(!$highPerformanceTeamsGroupsMembers){
return new JsonModel([
'success' => false,
'data' => 'ERROR_RECORD_NOT_FOUND'
]);
}
$member = $highPerformanceTeamsGroupsMembersMapper->fetchOneByGroupIdAndUserId($highPerformanceTeamsGroups->id,$currentUser->id);
if(!$member){
return new JsonModel([
'success' => false,
'data' => 'ERROR_YOU_DO_NOT_HAVE_ACCESS'
]);
}
if(!($member->status == HighPerformanceTeamsGroupsMembers::STATUS_ACCEPTED || $member->status == HighPerformanceTeamsGroupsMembers::STATUS_ADDED_BY_ADMIN) ){
return new JsonModel([
'success' => false,
'data' => 'ERROR_YOU_DO_NOT_HAVE_ACCESS'
]);
}
if($member->type==HighPerformanceTeamsGroupsMembers::TYPE_MODERATOR||$member->type==HighPerformanceTeamsGroupsMembers::TYPE_USER){
$allowDelete=false;
$allowEdit=false;
}
if($request->isGet()) {
$headers = $request->getHeaders();
$isJson = false;
if($headers->has('Accept')) {
$accept = $headers->get('Accept');
$prioritized = $accept->getPrioritized();
foreach($prioritized as $key => $value) {
$raw = trim($value->getRaw());
if(!$isJson) {
$isJson = strpos($raw, 'json');
}
}
}
if($isJson) {
$items=[];
foreach($highPerformanceTeamsGroupsMembers as $record)
{
$userType = $highPerformanceTeamsGroupsMembersMapper->fetchOneByGroupIdAndUserId($highPerformanceTeamsGroups->id,$record->id);
if($userType->status==HighPerformanceTeamsGroupsMembers::STATUS_ACCEPTED){
$contentAllowDelete2=$allowDelete;
$allowDelete=true;
}
if($userType->type==HighPerformanceTeamsGroupsMembers::TYPE_CREATOR){
$contentAllowDelete=$allowDelete;
$contentAllowEdit=$allowEdit;
$allowDelete=false;
$allowEdit=false;
}
$item = [
'first_name' => $record->first_name,
'last_name' => $record->last_name,
'image'=> $this->url()->fromRoute('storage', ['type' => 'user', 'code' => $record->uuid, 'filename' => $record->image]),
'link_delete' => $allowDelete ? $this->url()->fromRoute('high-performance-teams/groups/view/members/delete', ['group_id' => $highPerformanceTeamsGroups->uuid,'user_id'=>$record->uuid]) : '',
'link_edit' => $allowEdit ? $this->url()->fromRoute('high-performance-teams/groups/view/members/edit', ['group_id' => $highPerformanceTeamsGroups->uuid,'user_id'=>$record->uuid]) : '',
];
if($userType->type==HighPerformanceTeamsGroupsMembers::TYPE_CREATOR){
$allowDelete= $contentAllowDelete;
$allowEdit=$contentAllowEdit;
}
if($userType->status==HighPerformanceTeamsGroupsMembers::STATUS_ACCEPTED){
$allowDelete=$contentAllowDelete2;
}
array_push($items, $item);
}
return new JsonModel([
'success' => true,
'data' => [
'items' => $items
]
]);
}
}else if($request->isPost()){
$headers = $request->getHeaders();
$isJson = false;
if($headers->has('Accept')) {
$accept = $headers->get('Accept');
$prioritized = $accept->getPrioritized();
foreach($prioritized as $key => $value) {
$raw = trim($value->getRaw());
if(!$isJson) {
$isJson = strpos($raw, 'json');
}
}
}
if($isJson) {
$dataPost = $request->getPost()->toArray();
$search = $dataPost['search'];
$search = empty($search['value']) ? '' : Functions::sanitizeFilterString($search['value']);
$userMapper = UserMapper::getInstance($this->adapter);
$records = $userMapper->fetchAllSuggestForInvitationByHptgId($highPerformanceTeamsGroups->id,$highPerformanceTeamsGroups->company_id,$search);
$items=[];
foreach($records as $record)
{
$item = [
'first_name' => $record->first_name,
'last_name' => $record->last_name,
'image'=> $this->url()->fromRoute('storage', ['type' => 'user', 'code' => $record->uuid, 'filename' => $record->image]),
'email'=> $record->email,
'link_invite'=> $allowInvite ? $this->url()->fromRoute('high-performance-teams/groups/view/members/invite', ['group_id' => $highPerformanceTeamsGroups->uuid,'user_id'=>$record->uuid]) : '',
];
array_push($items, $item);
}
return new JsonModel([
'success' => true,
'data' => [
'items' => $items
]
]);
}
} else {
return new JsonModel([
'success' => false,
'data' => 'ERROR_METHOD_NOT_ALLOWED'
]);
}
}
public function inviteAction()
{
$currentUserPlugin = $this->plugin('currentUserPlugin');
$currentUser = $currentUserPlugin->getUser();
$currentCompany = $currentUserPlugin->getCompany();
$user_uuid = $this->params()->fromRoute('user_id');
$group_uuid = $this->params()->fromRoute('group_id');
$request = $this->getRequest();
if($request->isPost()) {
$userMapper = UserMapper::getInstance($this->adapter);
$user = $userMapper->fetchOneByUuid($user_uuid);
if(!$user) {
return new JsonModel([
'success' => false,
'data' => 'ERROR_RECORD_NOT_FOUND'
]);
}
$companyUserMapper = CompanyUserMapper::getInstance($this->adapter);
$companyUser = $companyUserMapper->fetchOneByCompanyIdAndUserId($currentCompany->id,$user->id);
$highPerformanceTeamsGroupsMapper = HighPerformanceTeamsGroupsMapper::getInstance($this->adapter);
$highPerformanceTeamsGroups = $highPerformanceTeamsGroupsMapper->fetchOneByUuid($group_uuid);
if(!$highPerformanceTeamsGroups) {
return new JsonModel([
'success' => false,
'data' => 'ERROR_RECORD_NOT_FOUND'
]);
}
$highPerformanceTeamsGroupsMembersMapper = HighPerformanceTeamsGroupsMembersMapper::getInstance($this->adapter);
$member = $highPerformanceTeamsGroupsMembersMapper->fetchOneByGroupIdAndUserId($highPerformanceTeamsGroups->id,$currentUser->id);
if(!$member){
return new JsonModel([
'success' => false,
'data' => 'ERROR_YOU_DO_NOT_HAVE_ACCESS'
]);
}
if($member->type==HighPerformanceTeamsGroupsMembers::TYPE_MODERATOR||$member->type==HighPerformanceTeamsGroupsMembers::TYPE_USER){
return new JsonModel([
'success' => false,
'data' => 'ERROR_METHOD_NOT_ALLOWED'
]);
}
$highPerformanceTeamsGroupsMember = new HighPerformanceTeamsGroupsMembers();
$highPerformanceTeamsGroupsMember->group_id = $highPerformanceTeamsGroups->id;
$highPerformanceTeamsGroupsMember->user_id = $user->id;
$highPerformanceTeamsGroupsMember->type = HighPerformanceTeamsGroupsMembers::TYPE_USER;
if($companyUser){
$highPerformanceTeamsGroupsMember->status = HighPerformanceTeamsGroupsMembers::STATUS_ADDED_BY_ADMIN;
$data = [
'success' => true,
'data' => 'LABEL_RECORD_ADDED'
];
}else{
$connectionMapper = ConnectionMapper::getInstance($this->adapter);
$connection = $connectionMapper->fetchOneByUserId1AndUserId2($currentUser->id, $user->id);
if(!$connection) {
return new JsonModel([
'success' => false,
'data' => 'ERROR_THIS_USER_IS_NOT_A_CONNECTION'
]);
}
$highPerformanceTeamsGroupsMember->status = HighPerformanceTeamsGroupsMembers::STATUS_INVITED;
$data = [
'success' => true,
'data' => 'LABEL_USER_COMPANY_HAS_BEEN_REQUESTED'
];
}
$highPerformanceTeamsGroupsMembersMapper->insert($highPerformanceTeamsGroupsMember);
if($highPerformanceTeamsGroupsMembersMapper) {
if($companyUser){
$chatGroupMapper = ChatGroupMapper::getInstance($this->adapter);
$chatGroup = $chatGroupMapper->fetchOneHptg($highPerformanceTeamsGroups->id);
if(!$chatGroup) {
return new JsonModel([
'success' => false,
'data' => 'ERROR_CHAT_GROUP_NOT_FOUND'
]);
}
$chatGroupUserMapper = ChatGroupUserMapper::getInstance($this->adapter);
$chatGroupOwner = $chatGroupUserMapper->fetchOwnerByGroupId($chatGroup->id);
$userMapper = UserMapper::getInstance($this->adapter);
$user = $userMapper->fetchOneByUuid($user_uuid);
if(!$user) {
return new JsonModel([
'success' => false,
'data' => 'ERROR_USER_NOT_FOUND'
]);
}
if($chatGroupOwner->user_id == $user->id) {
return new JsonModel([
'success' => false,
'data' => 'ERROR_CHAT_I_CAN_NOT_ADD_HIMSELF'
]);
}
$chatGroupUser = $chatGroupUserMapper->fetchOneByGroupIdAndUserId($chatGroup->id, $user->id);
if($chatGroupUser) {
return new JsonModel([
'success' => false,
'data' => 'ERROR_THIS_USER_ALREADY_EXISTS_IN_THIS_GROUP'
]);
}
$chatGroupUser = new ChatGroupUser();
$chatGroupUser->group_id = $chatGroup->id;
$chatGroupUser->user_id = $user->id;
$chatGroupUser->owner = ChatGroupUser::OWNER_NO;
$result = $chatGroupUserMapper->insert($chatGroupUser);
if(!$result) {
return new JsonModel([
'success' => false,
'data' => $chatGroupUserMapper->getError()
]);
}
}
$this->logger->info('Se agrego el miembro de grupo con el correo: ' . $user->email, ['user_id' => $currentUser->id, 'ip' => Functions::getUserIP()]);
$data = [
'success' => true,
'data' => 'LABEL_RECORD_ADDED'
];
} else {
$data = [
'success' => false,
'data' => $highPerformanceTeamsGroupsMembersMapper->getError()
];
}
return new JsonModel($data);
} else {
$data = [
'success' => false,
'data' => 'ERROR_METHOD_NOT_ALLOWED'
];
return new JsonModel($data);
}
return new JsonModel($data);
}
public function editAction(){
$currentUserPlugin = $this->plugin('currentUserPlugin');
$currentUser = $currentUserPlugin->getUser();
$currentCompany = $currentUserPlugin->getCompany();
$request = $this->getRequest();
$group_uuid = $this->params()->fromRoute('group_id');
$user_uuid = $this->params()->fromRoute('user_id');
if(!$group_uuid) {
$data = [
'success' => false,
'data' => 'ERROR_INVALID_PARAMETER'
];
return new JsonModel($data);
}
if(!$user_uuid) {
$data = [
'success' => false,
'data' => 'ERROR_INVALID_PARAMETER'
];
return new JsonModel($data);
}
$highPerformanceTeamsGroupsMapper = HighPerformanceTeamsGroupsMapper::getInstance($this->adapter);
$highPerformanceTeamsGroups = $highPerformanceTeamsGroupsMapper->fetchOneByUuid($group_uuid);
if (!$highPerformanceTeamsGroups) {
$data = [
'success' => false,
'data' => 'ERROR_RECORD_NOT_FOUND'
];
return new JsonModel($data);
}
$highPerformanceTeamsGroupsMembersMapper = HighPerformanceTeamsGroupsMembersMapper::getInstance($this->adapter);
$member = $highPerformanceTeamsGroupsMembersMapper->fetchOneByGroupIdAndUserId($highPerformanceTeamsGroups->id,$currentUser->id);
if(!$member){
return new JsonModel([
'success' => false,
'data' => 'ERROR_YOU_DO_NOT_HAVE_ACCESS'
]);
}
if($member->type==HighPerformanceTeamsGroupsMembers::TYPE_MODERATOR||$member->type==HighPerformanceTeamsGroupsMembers::TYPE_USER){
return new JsonModel([
'success' => false,
'data' => 'ERROR_METHOD_NOT_ALLOWED'
]);
}
$userMapper = UserMapper::getInstance($this->adapter);
$user = $userMapper->fetchOneByUuid($user_uuid);
$highPerformanceTeamsGroupsMembers=$highPerformanceTeamsGroupsMembersMapper->fetchOneByGroupIdAndUserId($highPerformanceTeamsGroups->id,$user->id);
if($highPerformanceTeamsGroupsMembers->type==HighPerformanceTeamsGroupsMembers::TYPE_CREATOR){
return new JsonModel([
'success' => false,
'data' => 'ERROR_METHOD_NOT_ALLOWED'
]);
}
if($request->isPost()) {
$form = new HighPerformanceTeamsGroupsMembersTypeForm($this->adapter, $currentCompany->id);
$dataPost = $request->getPost()->toArray();
$form->setData($dataPost);
if($form->isValid()) {
$dataPost = (array) $form->getData();
$hydrator = new ObjectPropertyHydrator();
$hydrator->hydrate($dataPost, $highPerformanceTeamsGroupsMembers);
$result = $highPerformanceTeamsGroupsMembersMapper->update($highPerformanceTeamsGroupsMembers);
if($result) {
$this->logger->info('Se actualizo el miembro ' .$user->first_name.' en el grupo '. $highPerformanceTeamsGroups->title, ['user_id' => $currentUser->id, 'ip' => Functions::getUserIP()]);
$data = [
'success' => true,
'data' => 'LABEL_RECORD_UPDATED'
];
} else {
$data = [
'success' => false,
'data' => $highPerformanceTeamsGroupsMembersMapper->getError()
];
}
return new JsonModel($data);
} else {
$messages = [];
$form_messages = (array) $form->getMessages();
foreach($form_messages as $fieldname => $field_messages)
{
$messages[$fieldname] = array_values($field_messages);
}
return new JsonModel([
'success' => false,
'data' => $messages
]);
}
}else if ($request->isGet()) {
$hydrator = new ObjectPropertyHydrator();
$data = [
'success' => true,
'data' => $highPerformanceTeamsGroupsMembers->type
];
return new JsonModel($data);
} else {
$data = [
'success' => false,
'data' => 'ERROR_METHOD_NOT_ALLOWED'
];
return new JsonModel($data);
}
return new JsonModel($data);
}
public function deleteAction(){
$currentUserPlugin = $this->plugin('currentUserPlugin');
$currentCompany = $currentUserPlugin->getCompany();
$currentUser = $currentUserPlugin->getUser();
$request = $this->getRequest();
$group_uuid = $this->params()->fromRoute('group_id');
$user_uuid = $this->params()->fromRoute('user_id');
if (!$group_uuid) {
$data = [
'success' => false,
'data' => 'ERROR_INVALID_PARAMETER'
];
return new JsonModel($data);
}
if (!$user_uuid) {
$data = [
'success' => false,
'data' => 'ERROR_INVALID_PARAMETER'
];
return new JsonModel($data);
}
if ($request->isPost()) {
$userMapper = UserMapper::getInstance($this->adapter);
$user = $userMapper->fetchOneByUuid($user_uuid);
if (!$user) {
$data = [
'success' => false,
'data' => 'ERROR_RECORD_NOT_FOUND'
];
return new JsonModel($data);
}
$highPerformanceTeamsGroupsMapper = HighPerformanceTeamsGroupsMapper::getInstance($this->adapter);
$highPerformanceTeamsGroups = $highPerformanceTeamsGroupsMapper->fetchOneByUuid($group_uuid);
if (!$highPerformanceTeamsGroups) {
$data = [
'success' => false,
'data' => 'ERROR_RECORD_NOT_FOUND'
];
return new JsonModel($data);
}
$highPerformanceTeamsGroupsMembersMapper = HighPerformanceTeamsGroupsMembersMapper::getInstance($this->adapter);
$highPerformanceTeamsGroupsMembers=$highPerformanceTeamsGroupsMembersMapper->fetchOneByGroupIdAndUserId($highPerformanceTeamsGroups->id,$user->id);
if($highPerformanceTeamsGroupsMembers->user_id!=$currentUser->id){
$member = $highPerformanceTeamsGroupsMembersMapper->fetchOneByGroupIdAndUserId($highPerformanceTeamsGroups->id,$currentUser->id);
if(!$member){
return new JsonModel([
'success' => false,
'data' => 'ERROR_YOU_DO_NOT_HAVE_ACCESS'
]);
}
if($member->type==HighPerformanceTeamsGroupsMembers::TYPE_MODERATOR||$member->type==HighPerformanceTeamsGroupsMembers::TYPE_USER){
return new JsonModel([
'success' => false,
'data' => 'ERROR_YOU_DO_NOT_HAVE_ACCESS'
]);
}
if($highPerformanceTeamsGroupsMembers->type==HighPerformanceTeamsGroupsMembers::TYPE_CREATOR){
return new JsonModel([
'success' => false,
'data' => 'ERROR_YOU_DO_NOT_HAVE_ACCESS'
]);
}
}else{
if($highPerformanceTeamsGroupsMembers->status != HighPerformanceTeamsGroupsMembers::STATUS_ACCEPTED){
return new JsonModel([
'success' => false,
'data' => 'ERROR_YOU_DO_NOT_HAVE_ACCESS'
]);
}
}
$chatGroupMapper = ChatGroupMapper::getInstance($this->adapter);
$chatGroup = $chatGroupMapper->fetchOneHptg($highPerformanceTeamsGroups->id);
if(!$chatGroup) {
return new JsonModel([
'success' => false,
'data' => 'ERROR_CHAT_GROUP_NOT_FOUND'
]);
}
$chatGroupUserMapper = ChatGroupUserMapper::getInstance($this->adapter);
$chatGroupOwner = $chatGroupUserMapper->fetchOwnerByGroupId($chatGroup->id);
$userMapper = UserMapper::getInstance($this->adapter);
$user = $userMapper->fetchOneByUuid($user_uuid);
if(!$user) {
return new JsonModel([
'success' => false,
'data' => 'ERROR_USER_NOT_FOUND'
]);
}
if($chatGroupOwner->user_id == $user->id) {
return new JsonModel([
'success' => false,
'data' => 'ERROR_CHAT_I_CAN_NOT_REMOVE_MYSELF'
]);
}
$chatGroupUser = $chatGroupUserMapper->fetchOneByGroupIdAndUserId($chatGroup->id, $user->id);
if(!$chatGroupUser) {
return new JsonModel([
'success' => false,
'data' => 'ERROR_CHAT_GROUP_YOU_NOT_MEMBER'
]);
}
$response = $chatGroupUserMapper->deleteByGroupIdAndUserId($chatGroup->id, $user->id);
if(!$response) {
return new JsonModel([
'success' => false,
'data' => $chatGroupMapper->getError()
]);
}
$result = $highPerformanceTeamsGroupsMembersMapper->delete($highPerformanceTeamsGroupsMembers->id);
if ($result) {
$this->logger->info('Se borro el grupo el miembro con el email de ' . $user->email, ['user_id' => $currentUser->id, 'ip' => Functions::getUserIP()]);
if($highPerformanceTeamsGroupsMembers->user_id==$currentUser->id){
return new JsonModel([
'success' => true,
'data' => 'LABEL_RECORD_DELETED',
'reload'=>true
]);
}
$data = [
'success' => true,
'data' => 'LABEL_RECORD_DELETED',
'reload'=>false
];
} else {
$data = [
'success' => false,
'data' => $highPerformanceTeamsGroupsMembersMapper->getError()
];
return new JsonModel($data);
}
} else {
$data = [
'success' => false,
'data' => 'ERROR_METHOD_NOT_ALLOWED'
];
return new JsonModel($data);
}
return new JsonModel($data);
}
}