Proyectos de Subversion LeadersLinked - Backend

    public function sendAllAction()

    {

        $request = $this->getRequest();

        if($request->isPost()) {

            $currentUserPlugin = $this->plugin('currentUserPlugin');

            $currentUser = $currentUserPlugin->getUser();

            $currentCompany = $currentUserPlugin->getCompany();

            $data = array_merge($request->getPost()->toArray(), $request->getFiles()->toArray());

            $form = new CommunicationInMailSendAllForm();

            $form->setData($data);

            if($form->isValid()) {

                $sendType=$form->get('type_send')->getValue();

                $users=[];

                if($sendType=='company_all'){

                    $companyUserMapper = CompanyUserMapper::getInstance($this->adapter);

                    $userMapper = UserMapper::getInstance($this->adapter);

                    $datosCompanyUser = $companyUserMapper->fetchAllByCompanyIdAndNotUserId($currentCompany->id, $currentUser->id);

                    foreach($datosCompanyUser as $record){

                        $datosUser = $userMapper->fetchOne($record->user_id);

                        array_push($users,  $datosUser);

                    }

                }else if($sendType=='studens_all'){

                    $userMapper = UserMapper::getInstance($this->adapter);

                    $datosCompanyUser = $userMapper->fetchAllStudensByCompanyId($currentCompany->id);

                    foreach($datosCompanyUser as $record){

                        $datosUser = $userMapper->fetchOne($record->id);

                        array_push($users,  $datosUser);

                    }

                }else{

                    return new JsonModel([

                        'success'  => false,

                        'data' => 'te falta amor, hermano'

                    ]);

                }

                foreach($users as $user){

                    $conversationMapper = ConversationMapper::getInstance($this->adapter);

                    $conversation = $conversationMapper->fetchOneByUserId1AndUserId2($currentUser->id, $user->id);

                    if($conversation) {

                        $conversation->receiver_status = Conversation::STATUS_NORMAL;

                        $conversation->sender_status = Conversation::STATUS_NORMAL;

                        if(!$conversationMapper->update($conversation)) {

                            return new JsonModel([

                                'success'  => false,

                                'data' => $conversationMapper->getError()

                            ]);

                        }

                    } else {

                        $conversation = new Conversation();

                        $conversation->sender_id = $currentUser->id;

                        $conversation->sender_status = Conversation::STATUS_NORMAL;

                        $conversation->receiver_id = $user->id;

                        $conversation->receiver_status = Conversation::STATUS_NORMAL;

                        if(!$conversationMapper->insert($conversation)) {

                            return new JsonModel([

                                'success'  => false,

                                'data' => $conversationMapper->getError()

                            ]);

                        }

                    }

                    $files = $this->getRequest()->getFiles()->toArray();

                    $type = Message::TYPE_TEXT;

                    $encoding = $this->params()->fromRoute('encoding');

                    if($encoding == 'base64') {

                        $fileBase64Name = $this->params()->fromPost('file_base64_name');

                        $fileBase64Content = $this->params()->fromPost('file_base64_content');

                        if($fileBase64Name && $fileBase64Content) {

                            try {

                                $fileBase64Content = base64_decode($fileBase64Content);

                                if($fileBase64Content) {

                                    $message_filename      = $this->normalizeString($fileBase64Name);

                                    $message_tmp_filename = 'data' . DIRECTORY_SEPARATOR . 'tmp';

                                    if(!file_exists($message_tmp_filename)) {

                                        mkdir($message_tmp_filename, 0755, true);

                                    }

                                    $message_tmp_filename = 'data' . DIRECTORY_SEPARATOR . 'tmp' . DIRECTORY_SEPARATOR . $message_filename;

                                    file_put_contents($message_tmp_filename, $fileBase64Content);

                                    $mime_type = mime_content_type($message_tmp_filename);

                                    //echo '$mime_type = '. $mime_type; exit;

                                    if($mime_type == 'image/jpg' || $mime_type == 'image/jpeg' || $mime_type == 'image/png') {

                                        $type = Message::TYPE_IMAGE;

                                    } else if($mime_type == 'video/webm' || $mime_type == 'video/mpeg' || $mime_type == 'video/mpg' || $mime_type == 'video/mp4') {

                                        $type = Message::FILE_TYPE_VIDEO;

                                    } else if($mime_type == 'application/pdf') {

                                        $type = Message::FILE_TYPE_DOCUMENT;

                                    }

                                }

                            } catch(\Exception $e) {

                            }

                        }

                    } else {

                        if(isset($files['file']) && empty($files['file']['error'])) {

                            $message_tmp_filename  = $files['file']['tmp_name'];

                            $message_filename      = $this->normalizeString($files['file']['name']);

                            $mime_type = mime_content_type($message_tmp_filename);

                            if($mime_type == 'image/jpg' || $mime_type == 'image/jpeg' || $mime_type == 'image/png') {

                                $type = Message::TYPE_IMAGE;

                            } else if($mime_type == 'video/webm' || $mime_type == 'video/mpeg' || $mime_type == 'video/mpg' || $mime_type == 'video/mp4') {

                                $type = Message::TYPE_VIDEO;

                            } else if($mime_type == 'application/pdf') {

                                $type = Message::TYPE_DOCUMENT;

                            }

                        }

                    }

                    $message = new Message();

                    $message->conversation_id = $conversation->id;

                    $message->read = Message::NO;

                    $message->message = $form->get('message')->getValue();

                    $message->receiver_id = $user->id;

                    $message->receiver_status = Message::STATUS_NORMAL;

                    $message->sender_id = $currentUser->id;

                    $message->sender_status = Message::STATUS_NORMAL;

                    $message->type = $type;

                    $messageMapper = MessageMapper::getInstance($this->adapter);

                    if($messageMapper->insert($message)) {

                        $message = $messageMapper->fetchOne($message->id);

                        if( $type == Message::TYPE_DOCUMENT) {

                            try {

                                $target_path = $this->config['leaderslinked.fullpath.message'] . $message->uuid;

                                if(!file_exists($target_path)) {

                                    mkdir($target_path, 0755);

                                }

                                $full_filename = $target_path  . DIRECTORY_SEPARATOR .$message_filename;

                                if($encoding == 'base64') {

                                    $resultMoveOrRename = rename($message_tmp_filename , $full_filename);

                                } else {

                                    $resultMoveOrRename = move_uploaded_file($message_tmp_filename , $full_filename);

                                }

                                if($resultMoveOrRename) {

                                    $message->type = $type;

                                    $message->filename = basename($message_filename);

                                    $messageMapper->update($message);

                                } else {

                                    error_log('no se pudo mover o renombrar el documento : ' . $message_tmp_filename . ' al directorio : ' . $full_filename );

                                }

                            } catch(\Throwable $e) {

                                error_log($e->getTraceAsString());

                            }

                        }

                        if( $type == Message::TYPE_IMAGE) {

                            try {

                                $target_path = $this->config['leaderslinked.fullpath.message'] . $message->uuid;

                                if(!file_exists($target_path)) {

                                    mkdir($target_path, 0755);

                                }

                                list($target_width, $target_height) = explode('x', $this->config['leaderslinked.image_sizes.message_image_size']);

                                $message_filename = substr($message_filename, 0, strrpos($message_filename, '.'))  . '.png';

                                $crop_to_dimensions = false;

                                if(Image::uploadImage($message_tmp_filename, $target_path, $message_filename, $target_width, $target_height, $crop_to_dimensions )) {

                                    $message->type = $type;

                                    $message->filename = basename($message_filename);

                                    $messageMapper->update($message);

                                }

                            } catch(\Throwable $e) {

                                error_log($e->getTraceAsString());

                            }

                        }

                        if( $type == Message::TYPE_VIDEO) {

                            try {

                                $target_path = $this->config['leaderslinked.fullpath.message'] . $message->uuid;

                                if(!file_exists($target_path)) {

                                    mkdir($target_path, 0755);

                                }

                                $full_filename = $target_path  . DIRECTORY_SEPARATOR . $message_filename;

                                if($encoding == 'base64') {

                                    $resultMoveOrRename = rename($message_tmp_filename , $full_filename);

                                } else {

                                    $resultMoveOrRename = move_uploaded_file($message_tmp_filename , $full_filename);

                                }

                                if($resultMoveOrRename) {

                                    $size = $this->config['leaderslinked.image_sizes.message_image_size'];

                                    $getFromSecound = 2;

                                    //extracción del cover

                                    $generateFileName = substr($message_filename, 0, strrpos($message_filename, '.'));

                                    $generateFile =  $target_path  . DIRECTORY_SEPARATOR . $generateFileName .  '.png';

                                    $cmd            = "/usr/bin/ffmpeg -i $full_filename -an -ss $getFromSecound -s $size $generateFile";

                                    exec($cmd);

                                    $message->type = $type;

                                    $message->filename = basename($message_filename);

                                    $message->image_preview = basename($generateFile);

                                    $messageMapper->update($message);

                                    $videoConvert = new VideoConvert();

                                    $videoConvert->filename = $full_filename;

                                    $videoConvert->type = VideoConvert::TYPE_FEED;

                                    $videoConvertMapper = VideoConvertMapper::getInstance($this->adapter);

                                    $videoConvertMapper->insert($videoConvert);

                                } else {

                                    error_log('no se pudo mover o renombrar el documento : ' . $message_tmp_filename . ' al directorio : ' . $full_filename );

                                }

                            } catch(\Throwable $e) {

                                error_log($e->getTraceAsString());

                            }

                        } 

                    } else {

                        return new JsonModel([

                            'success'   => false,

                            'data'   => $messageMapper->getError()

                        ]);

                    }

                }

                $message = $messageMapper->fetchOne($message->id);

                if($message->filename) {

                    $filename = $this->url()->fromRoute('storage', ['type' => 'message', 'filename' => $message->filename, 'code' => $message->uuid]);

                } else {

                    $filename = '';

                }

                $dt = \DateTime::createFromFormat('Y-m-d H:i:s', $message->added_on);

                return new JsonModel([

                    'success'   => true,

                    'data'   => 'Mensajes enviados con exito'

                ]);

            } 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 {

            return new JsonModel([

                'success' => false,

                'data' => 'ERROR_METHOD_NOT_ALLOWED'

            ]);

        }