You are still logged in. Please click here to log out first.
'); $this->handleRedirect(Zend_Auth::getInstance()->getIdentity()->member_id); } $formLogin = new Default_Form_Login(); if ($this->_request->isGet()) { // not a POST request $this->view->formLogin = $formLogin->populate(array('redirect' => $this->view->redirect)); $this->view->error = 0; return; } Zend_Registry::get('logger')->info(__METHOD__ - . PHP_EOL . ' - authentication attempt on host: ' . Zend_Registry::get('store_host') - . PHP_EOL . ' - param redirect: ' . $this->getParam('redirect') - . PHP_EOL . ' - from ip: ' . $this->_request->getClientIp() - . PHP_EOL . ' - http method: ' . $this->_request->getMethod() - . PHP_EOL . ' - csrf string: ' . (isset($_POST['login_csrf']) ? $_POST['login_csrf'] : '') + . PHP_EOL . ' - authentication attempt on host: ' . Zend_Registry::get('store_host') + . PHP_EOL . ' - param redirect: ' . $this->getParam('redirect') + . PHP_EOL . ' - from ip: ' . $this->_request->getClientIp() + . PHP_EOL . ' - http method: ' . $this->_request->getMethod() + . PHP_EOL . ' - csrf string: ' . (isset($_POST['login_csrf']) ? $_POST['login_csrf'] : '') ); if (false === Default_Model_CsrfProtection::validateCsrfToken($_POST['login_csrf'])) { Zend_Registry::get('logger')->info(__METHOD__ - . PHP_EOL . ' - ip: ' . $this->_request->getClientIp() - . PHP_EOL . ' - validate CSRF token failed:' - . PHP_EOL . ' - received token: ' . $_POST['login_csrf'] - . PHP_EOL . ' - stored token: ' . Default_Model_CsrfProtection::getCsrfToken() + . PHP_EOL . ' - ip: ' . $this->_request->getClientIp() + . PHP_EOL . ' - validate CSRF token failed:' + . PHP_EOL . ' - received token: ' . $_POST['login_csrf'] + . PHP_EOL . ' - stored token: ' . Default_Model_CsrfProtection::getCsrfToken() ); $this->view->error = 0; $this->view->formLogin = $formLogin; if ($this->_request->isXmlHttpRequest()) { $viewLoginForm = $this->view->render('authorization/partials/loginForm.phtml'); $this->_helper->json(array('status' => 'ok', 'message' => $viewLoginForm)); } return; } if (false === $formLogin->isValid($_POST)) { // form not valid Zend_Registry::get('logger')->info(__METHOD__ - . PHP_EOL . ' - ip: ' . $this->_request->getClientIp() - . PHP_EOL . ' - form not valid:' - . PHP_EOL . print_r($formLogin->getMessages(), true) + . PHP_EOL . ' - ip: ' . $this->_request->getClientIp() + . PHP_EOL . ' - form not valid:' + . PHP_EOL . print_r($formLogin->getMessages(), true) ); $this->view->formLogin = $formLogin; $this->view->errorText = 'index.login.error.auth'; $this->view->error = 1; if ($this->_request->isXmlHttpRequest()) { $viewLoginForm = $this->view->render('authorization/partials/loginForm.phtml'); $this->_helper->json(array('status' => 'ok', 'message' => $viewLoginForm)); } return; } $values = $formLogin->getValues(); $authModel = new Default_Model_Authorization(); $authResult = $authModel->authenticateUser($values['mail'], $values['password'], $values['remember_me']); if (false == $authResult->isValid()) { // authentication fail Zend_Registry::get('logger')->info(__METHOD__ - . PHP_EOL . ' - authentication fail.' - . PHP_EOL . ' - user: ' . $values['mail'] - . PHP_EOL . ' - remember_me: ' . $values['remember_me'] - . PHP_EOL . ' - ip: ' . $this->_request->getClientIp() - . PHP_EOL . print_r($authResult->getMessages(), true) + . PHP_EOL . ' - authentication fail.' + . PHP_EOL . ' - user: ' . $values['mail'] + . PHP_EOL . ' - remember_me: ' . $values['remember_me'] + . PHP_EOL . ' - ip: ' . $this->_request->getClientIp() + . PHP_EOL . print_r($authResult->getMessages(), true) ); if ($authResult->getCode() == Local_Auth_Result::MAIL_ADDRESS_NOT_VALIDATED) { $session = new Zend_Session_Namespace(); $session->mail_verify_member_id = $authResult->getIdentity(); if ($this->_request->isXmlHttpRequest()) { $viewMessage = $this->view->render('verify/resend.phtml'); $this->_helper->json(array('status' => 'ok', 'message' => $viewMessage)); } } $this->view->errorText = 'index.login.error.auth'; $this->view->formLogin = $formLogin; $this->view->error = 1; if ($this->_request->isXmlHttpRequest()) { $viewLoginForm = $this->view->render('authorization/partials/loginForm.phtml'); $this->_helper->json(array('status' => 'ok', 'message' => $viewLoginForm)); } return; } Zend_Registry::get('logger')->info(__METHOD__ - . PHP_EOL . ' - authentication successful.' - . PHP_EOL . ' - user: ' . $values['mail'] - . PHP_EOL . ' - user_id: ' . isset(Zend_Auth::getInstance()->getStorage()->read()->member_id) ? Zend_Auth::getInstance()->getStorage()->read()->member_id : '' - . PHP_EOL . ' - remember_me: ' . $values['remember_me'] - . PHP_EOL . ' - ip: ' . $this->_request->getClientIp() + . PHP_EOL . ' - authentication successful.' + . PHP_EOL . ' - user: ' . $values['mail'] + . PHP_EOL . ' - user_id: ' . isset(Zend_Auth::getInstance()->getStorage()->read()->member_id) ? Zend_Auth::getInstance()->getStorage()->read()->member_id : '' + . PHP_EOL . ' - remember_me: ' . $values['remember_me'] + . PHP_EOL . ' - ip: ' . $this->_request->getClientIp() ); - - + + $filter = new Local_Filter_Url_Encrypt(); $p = $filter->filter($values['password']); $sess = new Zend_Session_Namespace('ocs_meta'); $sess->phash = $p; $auth = Zend_Auth::getInstance(); $userId = $auth->getStorage()->read()->member_id; $jwt = Default_Model_Jwt::encode($userId); $sess->openid = $jwt; //If the user is a hive user, we have to update his password $this->changePasswordIfNeeded($userId, $values['password']); //$modelToken = new Default_Model_SingleSignOnToken(); //$data = array( // 'remember_me' => $values['remember_me'], // //'redirect' => $this->getParam('redirect'), // 'redirect' => $this->view->redirect, // 'action' => Default_Model_SingleSignOnToken::ACTION_LOGIN, // 'member_id' => $userId //); //$token_id = $modelToken->createToken($data); //setcookie(Default_Model_SingleSignOnToken::ACTION_LOGIN, $token_id, time() + 120, '/', // Local_Tools_ParseDomain::get_domain($this->getRequest()->getHttpHost()), null, true); - + //user has to correct his data? $modelReviewProfile = new Default_Model_ReviewProfileData(); if (false === $modelReviewProfile->hasValidProfile($auth->getStorage()->read())) { Zend_Registry::get('logger')->info(__METHOD__ - . PHP_EOL . ' - User has to change user data!' - . PHP_EOL . ' - error code: ' . print_r($modelReviewProfile->getErrorCode(), true) + . PHP_EOL . ' - User has to change user data!' + . PHP_EOL . ' - error code: ' . print_r($modelReviewProfile->getErrorCode(), + true) ); - + if ($this->_request->isXmlHttpRequest()) { $redirect = $this->getParam('redirect') ? '/redirect/' . $this->getParam('redirect') : ''; - $this->_helper->json(array('status' => 'ok', - 'redirect' => '/r/change/e/' . $modelReviewProfile->getErrorCode() . $redirect + $this->_helper->json(array( + 'status' => 'ok', + 'redirect' => '/r/change/e/' . $modelReviewProfile->getErrorCode() . $redirect )); } else { $this->getRequest()->setParam('member_id', $userId); $this->redirect("/r/change/e/" . $modelReviewProfile->getErrorCode(), $this->getAllParams()); } - + return; } // handle redirect $this->view->loginok = true; $this->handleRedirect($userId); } /** * @param int $userId * - * @throws Zend_Controller_Action_Exception + * @throws Zend_Exception * @throws Zend_Filter_Exception */ protected function handleRedirect($userId) { if (empty($this->view->redirect)) { Zend_Registry::get('logger')->info(__METHOD__ . PHP_EOL . ' - user_id: ' . $userId . PHP_EOL . ' - redirect: empty'); if ($this->_request->isXmlHttpRequest()) { $redirect_url = $this->encodeString('/member/' . $userId . '/activities/'); $redirect = '/home/redirectme?redirect=' . $redirect_url; $this->_helper->json(array('status' => 'ok', 'redirect' => $redirect)); return; } $this->getRequest()->setParam('member_id', $userId); $redirect_url = $this->encodeString('/member/' . $userId . '/activities/'); $redirect = '/home/redirectme?redirect=' . $redirect_url; $this->redirect($redirect, $this->getAllParams()); return; } $redirect = $this->decodeString($this->view->redirect); Zend_Registry::get('logger')->info(__METHOD__ . PHP_EOL . ' - user_id: ' . $userId . PHP_EOL . ' - redirect: ' . $redirect); if (false !== strpos('/register', $redirect)) { $redirect = '/member/' . $userId . '/activities/'; } $redirect = '/home/redirectme?redirect=' . $this->encodeString($redirect); if ($this->_request->isXmlHttpRequest()) { $this->_helper->json(array('status' => 'ok', 'redirect' => $redirect)); return; } $this->redirect($redirect); return; } + /** + * @param string $string + * + * @return string + * @throws Zend_Filter_Exception + */ + protected function encodeString($string) + { + $encodeFilter = new Local_Filter_Url_Encrypt(); + + return $encodeFilter->filter($string); + } + /** * @throws Exception * @throws Zend_Exception * @throws Zend_Form_Exception */ public function registerAction() { $this->view->redirect = $this->getParam('redirect'); $this->view->headScript()->appendFile('//www.google.com/recaptcha/api.js'); $this->view->addHelperPath(APPLICATION_LIB . '/Cgsmith/View/Helper', 'Cgsmith\\View\\Helper\\'); $formRegister = new Default_Form_Register(); if ($this->_request->isGet()) { $this->view->formRegister = $formRegister->populate(array('redirect' => urlencode($this->view->redirect))); $this->view->error = 0; return; } if (false === $formRegister->isValid($_POST)) { $this->view->formRegister = $formRegister; $this->view->error = 1; if ($this->_request->isXmlHttpRequest()) { $viewRegisterForm = $this->view->render('authorization/partials/registerForm.phtml'); $this->_helper->json(array('status' => 'ok', 'message' => $viewRegisterForm)); return; } return; } $formRegisterValues = $formRegister->getValues(); unset($formRegisterValues['g-recaptcha-response']); $formRegisterValues['password'] = $formRegisterValues['password1']; $formRegisterValues['username'] = Default_Model_HtmlPurify::purify($formRegisterValues['username']); $formRegisterValues['mail'] = strtolower($formRegisterValues['mail']); $newUserData = $this->createNewUser($formRegisterValues); Default_Model_ActivityLog::logActivity($newUserData['main_project_id'], null, $newUserData['member_id'], Default_Model_ActivityLog::MEMBER_JOINED, array()); $this->sendConfirmationMail($formRegisterValues, $newUserData['verificationVal']); Zend_Registry::get('logger')->debug(__METHOD__ . ' - member_id: ' . $newUserData['member_id'] . ' - Link for verification: ' - . 'http://' . $this->getServerName() . '/verification/' . $newUserData['verificationVal']) - ; + . 'http://' . $this->getServerName() . '/verification/' . $newUserData['verificationVal']); if ($this->_request->isXmlHttpRequest()) { $viewRegisterForm = $this->view->render('authorization/partials/registerSuccess.phtml'); $this->_helper->json(array('status' => 'ok', 'message' => $viewRegisterForm)); } else { $this->view->overlay = $this->view->render('authorization/registerSuccess.phtml'); $this->forward('index', 'explore', 'default'); } } /** * @param array $userData * * @return array * @throws Exception */ protected function createNewUser($userData) { $userTable = new Default_Model_Member(); $userData = $userTable->createNewUser($userData); return $userData; } /** * @param array $val * @param string $verificationVal */ protected function sendConfirmationMail($val, $verificationVal) { $confirmMail = new Default_Plugin_SendMail('tpl_verify_user'); $confirmMail->setTemplateVar('servername', $this->getServerName()); $confirmMail->setTemplateVar('username', $val['username']); $confirmMail->setTemplateVar('verificationlinktext', 'Click here to verify your email address'); $confirmMail->setTemplateVar('verificationlink', 'https://' . $this->getServerName() . '/verification/' . $verificationVal . ''); - $confirmMail->setTemplateVar('verificationurl', 'https://' . $this->getServerName() . '/verification/' . $verificationVal); + $confirmMail->setTemplateVar('verificationurl', + 'https://' . $this->getServerName() . '/verification/' . $verificationVal); $confirmMail->setReceiverMail($val['mail']); $confirmMail->setFromMail('registration@opendesktop.org'); $confirmMail->send(); } /** * @return mixed */ protected function getServerName() { /** @var Zend_Controller_Request_Http $request */ $request = $this->getRequest(); return $request->getHttpHost(); } /** * @throws Zend_Controller_Action_Exception * @throws Zend_Exception * @throws Zend_Session_Exception */ public function propagatelogoutAction() { $this->_helper->layout()->disableLayout(); $this->_helper->viewRenderer->setNoRender(true); if (false == Zend_Auth::getInstance()->hasIdentity()) { $this->_helper->json(array('status' => 'ok', 'message' => 'Already logged out.')); } $modelAuth = new Default_Model_Authorization(); $modelAuth->logout(); $this->_helper->json(array('status' => 'ok', 'message' => 'Logout successful.')); } /** * @throws Zend_Cache_Exception * @throws Zend_Controller_Action_Exception * @throws Zend_Exception * @throws Zend_Session_Exception */ public function logoutAction() { $this->_helper->layout()->disableLayout(); $this->_helper->viewRenderer->setNoRender(true); if (Zend_Auth::getInstance()->hasIdentity()) { $modelAuth = new Default_Model_Authorization(); $modelAuth->logout(); $modelToken = new Default_Model_SingleSignOnToken(); $data = array( 'remember_me' => false, 'redirect' => $this->getParam('redirect'), 'action' => Default_Model_SingleSignOnToken::ACTION_LOGOUT ); $token_id = $modelToken->createToken($data); setcookie(Default_Model_SingleSignOnToken::ACTION_LOGOUT, $token_id, time() + 120, '/', Local_Tools_ParseDomain::get_domain($this->getRequest()->getHttpHost()), null, true); } if ($this->_request->isXmlHttpRequest()) { $this->_helper->json(array('status' => 'ok', 'message' => 'Logout successful.')); } else { $this->redirect('/'); } } public function init() { parent::init(); // TODO: Change the autogenerated stub - $this->getResponse()->clearHeaders(array('Expires', 'Pragma', 'Cache-Control'))->setHeader('Pragma', 'no-cache', true) - ->setHeader('Cache-Control', 'private, no-cache, must-revalidate', true) - ; + $this->getResponse()->clearHeaders(array('Expires', 'Pragma', 'Cache-Control'))->setHeader('Pragma', 'no-cache', + true) + ->setHeader('Cache-Control', 'private, no-cache, must-revalidate', true); } /** * @throws Zend_Auth_Storage_Exception * @throws Zend_Controller_Action_Exception * @throws Zend_Exception * @throws exception */ public function verificationAction() { $filterInput = new Zend_Filter_Input(array('*' => 'StringTrim', 'vid' => 'Alnum'), array('vid' => array('Alnum', 'presence' => 'required')), $this->getAllParams()); $_vId = $filterInput->getEscaped('vid'); if (!$_vId) { $this->redirect('/'); } $translate = Zend_Registry::get('Zend_Translate'); $this->view->title = $translate->_('member.email.verification.title'); $authModel = new Default_Model_Authorization(); $authUser = $authModel->getAuthUserDataFromUnverified($_vId); if (empty($authUser)) { throw new Zend_Controller_Action_Exception('This member account could not activated. verification id:' - . print_r($this->getParam('vid'), true)); + . print_r($this->getParam('vid'), true)); } if ($authUser AND (false == empty($authUser->email_checked))) { $this->view->headScript()->appendFile('//www.google.com/recaptcha/api.js'); $this->view->addHelperPath(APPLICATION_LIB . '/Cgsmith/View/Helper', 'Cgsmith\\View\\Helper\\'); $this->view->formRegister = new Default_Form_Register(); $this->view->registerErrMsg = "Your account has already been activated.
Log in or try to generate a new password for your account.
"; $this->view->overlay = $this->view->render('authorization/registerError.phtml'); $this->_helper->viewRenderer('register'); return; } Zend_Registry::get('logger')->info(__METHOD__ . ' - activate user from email link. (member_id, username): (' - . print_r($authUser->member_id, true) . ', ' . print_r($authUser->username, true) . ')') - ; + . print_r($authUser->member_id, true) . ', ' . print_r($authUser->username, + true) . ')'); $modelMember = new Default_Model_Member(); $result = $modelMember->activateMemberFromVerification($authUser->member_id, $_vId); if (false == $result) { throw new Zend_Controller_Action_Exception('Your member account could not activated.'); } - Zend_Registry::get('logger')->info(__METHOD__ . ' - user activated. member_id: ' . print_r($authUser->member_id, true)); + Zend_Registry::get('logger')->info(__METHOD__ . ' - user activated. member_id: ' . print_r($authUser->member_id, + true)); $modelMember = new Default_Model_Member(); $record = $modelMember->fetchMemberData($authUser->member_id, false); try { $oauth = new Default_Model_Ocs_OAuth(); $oauth->createUserFromArray($record->toArray()); - Zend_Registry::get('logger')->debug(__METHOD__ . ' - oauth : ' . implode(PHP_EOL." - ", $oauth->getMessages())); + Zend_Registry::get('logger')->debug(__METHOD__ . ' - oauth : ' . implode(PHP_EOL . " - ", + $oauth->getMessages())); } catch (Exception $e) { Zend_Registry::get('logger')->err($e->getMessage() . PHP_EOL . $e->getTraceAsString()); } try { $ldap = new Default_Model_Ocs_Ldap(); $ldap->createUserFromArray($record->toArray()); - Zend_Registry::get('logger')->debug(__METHOD__ . ' - ldap : ' . implode(PHP_EOL." - ", $ldap->getMessages())); + Zend_Registry::get('logger')->debug(__METHOD__ . ' - ldap : ' . implode(PHP_EOL . " - ", + $ldap->getMessages())); } catch (Exception $e) { Zend_Registry::get('logger')->err($e->getMessage() . PHP_EOL . $e->getTraceAsString()); } try { $openCode = new Default_Model_Ocs_Gitlab(); $openCode->createUserFromArray($record->toArray()); - Zend_Registry::get('logger')->debug(__METHOD__ . ' - opencode : ' . implode(PHP_EOL." - ", $openCode->getMessages())); + Zend_Registry::get('logger')->debug(__METHOD__ . ' - opencode : ' . implode(PHP_EOL . " - ", + $openCode->getMessages())); } catch (Exception $e) { Zend_Registry::get('logger')->err($e->getMessage() . PHP_EOL . $e->getTraceAsString()); } try { $forum = new Default_Model_Ocs_Forum(); $forum->createUserFromArray($record->toArray()); - Zend_Registry::get('logger')->debug(__METHOD__ . ' - forum : ' . implode(PHP_EOL." - ", $forum->getMessages())); + Zend_Registry::get('logger')->debug(__METHOD__ . ' - forum : ' . implode(PHP_EOL . " - ", + $forum->getMessages())); } catch (Exception $e) { Zend_Registry::get('logger')->err($e->getMessage() . PHP_EOL . $e->getTraceAsString()); } Default_Model_ActivityLog::logActivity($authUser->member_id, null, $authUser->member_id, Default_Model_ActivityLog::MEMBER_EMAIL_CONFIRMED, array()); $this->view->member = $authUser; $this->view->username = $authUser->username; $this->view->headScript()->appendFile('//www.google.com/recaptcha/api.js'); $this->view->addHelperPath(APPLICATION_LIB . '/Cgsmith/View/Helper', 'Cgsmith\\View\\Helper\\'); $this->view->form = new Default_Form_Register(); $this->view->overlay = $this->view->render('authorization/registerWelcome.phtml'); $this->storeAuthSessionData($authUser->member_id); $tableProduct = new Default_Model_Project(); $this->view->products = $tableProduct->fetchAllProjectsForMember($authUser->member_id); $this->forward('index', 'settings', 'default', array('member_id' => $authUser->member_id)); } /** * @param string|int $identity * * @throws Zend_Auth_Storage_Exception * @throws exception */ protected function storeAuthSessionData($identity) { $authDataModel = new Default_Model_Authorization(); $authDataModel->storeAuthSessionDataByIdentity($identity); } /** * ppload */ public function pploadloginAction() { $this->_helper->layout()->disableLayout(); // Init identity and credential $identity = null; $credential = null; if (!empty($_REQUEST['identity'])) { $identity = $_REQUEST['identity']; } else { if (!empty($_SERVER['PHP_AUTH_USER'])) { $identity = $_SERVER['PHP_AUTH_USER']; } } if (!empty($_REQUEST['credential'])) { $credential = $_REQUEST['credential']; } else { if (!empty($_SERVER['PHP_AUTH_PW'])) { $credential = $_SERVER['PHP_AUTH_PW']; } } // Authenticate and get user data $response = array('status' => 'error'); if ($identity && $credential) { $authModel = new Default_Model_Authorization(); $authData = $authModel->getAuthDataFromApi($identity, $credential); if (!empty($authData->member_id)) { $response = array( 'status' => 'ok', 'member_id' => $authData->member_id ); } } $this->_helper->json($response); } public function htmlloginAction() { $this->_helper->layout()->disableLayout(); //$this->_helper->viewRenderer->setNoRender(true); } public function validateAction() { $this->_helper->layout->disableLayout(); $this->_helper->viewRenderer->setNoRender(true); $this->view->headScript()->appendFile('//www.google.com/recaptcha/api.js'); $this->view->addHelperPath(APPLICATION_LIB . '/Cgsmith/View/Helper', 'Cgsmith\\View\\Helper\\'); $formRegister = new Default_Form_Register(); $name = $this->getParam('name'); $value = $this->getParam('value'); $result = $formRegister->getElement($name)->isValid($value); $this->_helper->json(array('status' => $result, $name => $formRegister->getElement($name)->getMessages())); } - /** - * @param string $string - * - * @return string - * @throws Zend_Filter_Exception - */ - protected function encodeString($string) - { - $encodeFilter = new Local_Filter_Url_Encrypt(); - - return $encodeFilter->filter($string); - } - /** * @param array $val * * @throws Zend_Exception */ protected function sendAdminNotificationMail($val) { $config = Zend_Registry::get('config'); $receiver = $config->admin->email; $oNotificationMail = new Default_Plugin_SendMail('tpl_newuser_notification'); $oNotificationMail->setReceiverMail($receiver); $oNotificationMail->setTemplateVar('username', $val['username']); $oNotificationMail->send(); } /** * @param array $userData * * @return int */ protected function storeNewUser($userData) { $userTable = new Default_Model_Member(); $userData = $userTable->storeNewUser($userData); return $userData->member_id; } /** * @param int $identity */ protected function updateUsersLastOnline($identity) { $authModel = new Default_Model_Authorization(); $authModel->updateUserLastOnline('member_id', $identity); } } \ No newline at end of file diff --git a/application/modules/default/controllers/ProductController.php b/application/modules/default/controllers/ProductController.php index cab9b8cf3..8727a0b0d 100644 --- a/application/modules/default/controllers/ProductController.php +++ b/application/modules/default/controllers/ProductController.php @@ -1,3042 +1,3042 @@ . **/ class ProductController extends Local_Controller_Action_DomainSwitch { const IMAGE_SMALL_UPLOAD = 'image_small_upload'; const IMAGE_BIG_UPLOAD = 'image_big_upload'; /** * Zend_Controller_Request_Abstract object wrapping the request environment * * @var Zend_Controller_Request_Http */ protected $_request = null; /** @var int */ protected $_projectId; /** @var int */ protected $_collectionId; /** @var Zend_Auth */ protected $_auth; /** @var string */ protected $_browserTitlePrepend; public function init() { parent::init(); $this->_projectId = (int)$this->getParam('project_id'); $this->_collectionId = (int)$this->getParam('collection_id'); $this->_auth = Zend_Auth::getInstance(); $this->_browserTitlePrepend = $this->templateConfigData['head']['browser_title_prepend']; $action = $this->getRequest()->getActionName(); $title = $action; if($action =='add') { $title = 'add product'; }else { $title = $action; } $this->view->headTitle($title . ' - ' . $this->getHeadTitle(), 'SET'); } public function ratingAction() { $this->_helper->layout()->disableLayout(); if (array_key_exists($this->_projectId, $this->_authMember->projects)) { return; } $userRating = (int)$this->getParam('rate', 0); $modelRating = new Default_Model_DbTable_ProjectRating(); $modelRating->rateForProject($this->_projectId, $this->_authMember->member_id, $userRating); } public function pploadAction() { $this->_helper->layout->disableLayout(); $modelProduct = new Default_Model_Project(); $productInfo = $modelProduct->fetchProductInfo($this->_projectId); //create ppload download hash: secret + collection_id + expire-timestamp $salt = PPLOAD_DOWNLOAD_SECRET; $collectionID = $productInfo->ppload_collection_id; $timestamp = time() + 3600; // one hour valid //20181009 ronald: change hash from MD5 to SHA512 //$hash = md5($salt . $collectionID . $timestamp); // order isn't important at all... just do the same when verifying $hash = hash('sha512',$salt . $collectionID . $timestamp); // order isn't important at all... just do the same when verifying $this->view->download_hash = $hash; $this->view->download_timestamp = $timestamp; $this->view->product = $productInfo; $this->_helper->viewRenderer('/partials/pploadajax'); } public function gettaggroupsforcatajaxAction() { $this->_helper->layout()->disableLayout(); $catId = null; $fileId = null; if($this->hasParam('file_id')) { $fileId = $this->getParam('file_id'); } if($this->hasParam('project_cat_id')) { $catId = $this->getParam('project_cat_id'); $catTagModel = new Default_Model_Tags(); $catTagGropuModel = new Default_Model_TagGroup(); $tagGroups = $catTagGropuModel->fetchTagGroupsForCategory($catId); $tableTags = new Default_Model_DbTable_Tags(); $result = array(); $resultGroup = array(); foreach ($tagGroups as $group) { $tags = $tableTags->fetchForGroupForSelect($group['tag_group_id']); $selectedTags = null; if(!empty($fileId)) { $selectedTags = $catTagModel->getTagsArray($fileId, Default_Model_DbTable_Tags::TAG_TYPE_FILE,$group['tag_group_id']); } $group['tag_list'] = $tags; $group['selected_tags'] = $selectedTags; $result[] = $group; } $this->_helper->json(array('status' => 'ok', 'ResultSize' => count($tagGroups), 'tag_groups' => $result)); return; } $this->_helper->json(array('status' => 'error')); } private function getTagGroupsForCat($fileId) { $modelProduct = new Default_Model_Project(); $productInfo = $modelProduct->fetchProductInfo($this->_projectId); $catId = $productInfo->project_category_id; if(!empty($catId)) { $catTagModel = new Default_Model_Tags(); $catTagGropuModel = new Default_Model_TagGroup(); $tagGroups = $catTagGropuModel->fetchTagGroupsForCategory($catId); $tableTags = new Default_Model_DbTable_Tags(); $result = array(); foreach ($tagGroups as $group) { $tags = $tableTags->fetchForGroupForSelect($group['tag_group_id']); $selectedTags = null; if(!empty($fileId)) { $selectedTags = $catTagModel->getTagsArray($fileId, Default_Model_DbTable_Tags::TAG_TYPE_FILE,$group['tag_group_id']); } $group['tag_list'] = $tags; $group['selected_tags'] = $selectedTags; $result[] = $group; } return $result; } return null; } private function getFileDownloadCount($collection_id, $fileId) { $modelFiles = new Default_Model_DbTable_PploadFiles(); $countAll = $modelFiles->fetchCountDownloadsForFileAllTime($collection_id, $fileId); $countToday = $modelFiles->fetchCountDownloadsForFileToday($collection_id, $fileId); $count = (int)$countAll+ (int)$countToday; return $count; } public function listsamesourceurlAction() { $this->_helper->layout()->disableLayout(); $this->_helper->viewRenderer->setNoRender(true); $modelProduct = new Default_Model_Project(); $productInfo = $modelProduct->fetchProductInfo($this->_projectId); $result = $modelProduct->getSourceUrlProjects($productInfo->source_url); $r = 'You did not choose a Category in the last level.
'); $this->forward('add'); return; } //update the gallery pics $mediaServerUrls = $this->saveGalleryPics($form->gallery->upload->upload_picture); $modelProject->updateGalleryPictures($newProject->project_id, $mediaServerUrls); //If there is no Logo, we take the 1. gallery pic if (!isset($values['image_small']) || $values['image_small'] == '') { $values['image_small'] = $mediaServerUrls[0]; $newProject = $modelProject->updateProject($newProject->project_id, $values); } //New Project in Session, for AuthValidation (owner) $this->_auth->getIdentity()->projects[$newProject->project_id] = array('project_id' => $newProject->project_id); $modelTags = new Default_Model_Tags(); if ($values['tagsuser']) { $modelTags->processTagsUser($newProject->project_id, implode(',', $values['tagsuser']),Default_Model_Tags::TAG_TYPE_PROJECT); } else { $modelTags->processTagsUser($newProject->project_id, null, Default_Model_Tags::TAG_TYPE_PROJECT); } if ($values['is_original']) { $modelTags->processTagProductOriginal($newProject->project_id, $values['is_original']); } //set license, if needed $licenseTag = $form->getElement('license_tag_id')->getValue(); //only set/update license tags if something was changed if ($licenseTag && count($licenseTag) > 0) { $modelTags->saveLicenseTagForProject($newProject->project_id, $licenseTag); $activityLog = new Default_Model_ActivityLog(); $activityLog->logActivity($newProject->project_id, $newProject->project_id, $this->_authMember->member_id,Default_Model_ActivityLog::PROJECT_LICENSE_CHANGED, array('title' => 'Set new License Tag', 'description' => 'New TagId: ' . $licenseTag)); } $isGitlabProject = $form->getElement('is_gitlab_project')->getValue(); $gitlabProjectId = $form->getElement('gitlab_project_id')->getValue(); if ($isGitlabProject && $gitlabProjectId == 0) { $values['gitlab_project_id'] = null; } $activityLog = new Default_Model_ActivityLog(); $activityLog->writeActivityLog($newProject->project_id, $newProject->member_id, Default_Model_ActivityLog::PROJECT_CREATED, $newProject->toArray()); // ppload $this->processPploadId($newProject); try { if (100 < $this->_authMember->roleId) { if (Default_Model_Spam::hasSpamMarkers($newProject->toArray())) { $tableReportComments = new Default_Model_DbTable_ReportProducts(); $tableReportComments->save(array('project_id' => $newProject->project_id, 'reported_by' => 24, 'text' => "System: automatic spam detection")); } Default_Model_DbTable_SuspicionLog::logProject($newProject, $this->_authMember, $this->getRequest()); } } catch (Zend_Exception $e) { Zend_Registry::get('logger')->err($e->getMessage()); } $this->redirect('/member/' . $newProject->member_id . '/products/'); } private function saveGalleryPics($form_element) { $imageModel = new Default_Model_DbTable_Image(); return $imageModel->saveImages($form_element); } /** * @param $projectData * * @throws Zend_Exception * @throws Zend_Queue_Exception */ protected function createTaskWebsiteOwnerVerification($projectData) { if (empty($projectData->link_1)) { return; } $checkAuthCode = new Local_Verification_WebsiteProject(); $authCode = $checkAuthCode->generateAuthCode(stripslashes($projectData->link_1)); $queue = Local_Queue_Factory::getQueue(); $command = new Backend_Commands_CheckProjectWebsite($projectData->project_id, $projectData->link_1, $authCode); $queue->send(serialize($command)); } /** * @param $projectData */ protected function processPploadId($projectData) { if ($projectData->ppload_collection_id) { $pploadApi = new Ppload_Api(array( 'apiUri' => PPLOAD_API_URI, 'clientId' => PPLOAD_CLIENT_ID, 'secret' => PPLOAD_SECRET )); // Update collection information $collectionCategory = $projectData->project_category_id; if (Default_Model_Project::PROJECT_ACTIVE == $projectData->status) { $collectionCategory .= '-published'; } $collectionRequest = array( 'title' => $projectData->title, 'description' => $projectData->description, 'category' => $collectionCategory, 'content_id' => $projectData->project_id ); $collectionResponse = $pploadApi->putCollection($projectData->ppload_collection_id, $collectionRequest); // Store product image as collection thumbnail $this->_updatePploadMediaCollectionthumbnail($projectData); } } /** * ppload */ protected function _updatePploadMediaCollectionthumbnail($projectData) { if (empty($projectData->ppload_collection_id) || empty($projectData->image_small) ) { return false; } $pploadApi = new Ppload_Api(array( 'apiUri' => PPLOAD_API_URI, 'clientId' => PPLOAD_CLIENT_ID, 'secret' => PPLOAD_SECRET )); $filename = sys_get_temp_dir() . '/' . $projectData->image_small; if (false === file_exists(dirname($filename))) { mkdir(dirname($filename), 0777, true); } $viewHelperImage = new Default_View_Helper_Image(); $uri = $viewHelperImage->Image($projectData->image_small, array( 'width' => 600, 'height' => 600 )); file_put_contents($filename, file_get_contents($uri)); $mediaCollectionthumbnailResponse = $pploadApi->postMediaCollectionthumbnail($projectData->ppload_collection_id, array('file' => $filename)); unlink($filename); if (isset($mediaCollectionthumbnailResponse->status) && $mediaCollectionthumbnailResponse->status == 'success' ) { return true; } return false; } public function editAction() { if (empty($this->_projectId)) { $this->redirect($this->_helper->url('add')); return; } $this->_helper->viewRenderer('add'); // we use the same view as you can see at add a product $this->view->mode = 'edit'; $projectTable = new Default_Model_DbTable_Project(); $projectModel = new Default_Model_Project(); $modelTags = new Default_Model_Tags(); $tagTable = new Default_Model_DbTable_Tags(); //check if product with given id exists $projectData = $projectTable->find($this->_projectId)->current(); if (empty($projectData)) { $this->redirect($this->_helper->url('add')); return; } $member = null; if (isset($this->_authMember) AND (false === empty($this->_authMember->member_id))) { $member = $this->_authMember; } else { throw new Zend_Controller_Action_Exception('no authorization found'); } if (("admin" == $this->_authMember->roleName)) { $modelMember = new Default_Model_Member(); $member = $modelMember->fetchMember($projectData->member_id, false); } //set ppload-collection-id in view $this->view->ppload_collection_id = $projectData->ppload_collection_id; $this->view->project_id = $projectData->project_id; $this->view->product = $projectData; //create ppload download hash: secret + collection_id + expire-timestamp $salt = PPLOAD_DOWNLOAD_SECRET; $collectionID = $projectData->ppload_collection_id; $timestamp = time() + 3600; // one hour valid //20181009 ronald: change hash from MD5 to SHA512 //$hash = md5($salt . $collectionID . $timestamp); // order isn't important at all... just do the same when verifying $hash = hash('sha512',$salt . $collectionID . $timestamp); // order isn't important at all... just do the same when verifying $this->view->download_hash = $hash; $this->view->download_timestamp = $timestamp; $this->view->member_id = $member->member_id; $this->view->member = $member; //read the already existing gallery pics and add them to the form $sources = $projectModel->getGalleryPictureSources($this->_projectId); //get the gitlab projects for this user //setup form $form = new Default_Form_Product(array('pictures' => $sources, 'member_id' => $this->view->member_id)); if (false === empty($projectData->image_small)) { $form->getElement('image_small_upload')->setRequired(false); } $form->getElement('preview')->setLabel('Save'); $form->removeElement('project_id'); // we don't need this field in edit mode if ($this->_request->isGet()) { $form->populate($projectData->toArray()); // $form->populate(array('tags' => $modelTags->getTags($projectData->project_id, Default_Model_Tags::TAG_TYPE_PROJECT))); $form->populate(array('tagsuser' => $modelTags->getTagsUser($projectData->project_id, Default_Model_Tags::TAG_TYPE_PROJECT))); $form->getElement('image_small')->setValue($projectData->image_small); //Bilder voreinstellen $form->getElement(self::IMAGE_SMALL_UPLOAD)->setValue($projectData->image_small); $licenseTags = $tagTable->fetchLicenseTagsForProject($this->_projectId); $licenseTag = null; if($licenseTags) { $licenseTag = $licenseTags[0]['tag_id']; } $form->getElement('license_tag_id')->setValue($licenseTag); $is_original = $modelTags->isProuductOriginal($projectData->project_id); if($is_original){ $form->getElement('is_original')->checked= true; } $this->view->form = $form; return; } if (isset($_POST['cancel'])) { // user cancel function $this->redirect('/member/' . $member->member_id . '/news/'); } if (false === $form->isValid($_POST, $this->_projectId)) { // form not valid $this->view->form = $form; $this->view->error = 1; return; } $values = $form->getValues(); //set license, if needed $tagList = $modelTags->getTagsArray($this->_projectId, $modelTags::TAG_TYPE_PROJECT, $modelTags::TAG_LICENSE_GROUPID); $oldLicenseTagId = null; if($tagList && count($tagList) == 1) { $oldLicenseTagId = $tagList[0]['tag_id']; } $licenseTag = $form->getElement('license_tag_id')->getValue(); //only set/update license tags if something was changed if($licenseTag <> $oldLicenseTagId) { $modelTags->saveLicenseTagForProject($this->_projectId, $licenseTag); $activityLog = new Default_Model_ActivityLog(); $activityLog->logActivity($this->_projectId, $this->_projectId, $this->_authMember->member_id, Default_Model_ActivityLog::PROJECT_LICENSE_CHANGED, array('title' => 'License Tag', 'description' => 'Old TagId: '.$oldLicenseTagId.' - New TagId: '.$licenseTag)); } //gitlab project $isGitlabProject = $form->getElement('is_gitlab_project')->getValue(); $gitlabProjectId = $form->getElement('gitlab_project_id')->getValue(); if($isGitlabProject && $gitlabProjectId == 0) { $values['gitlab_project_id'] = null; } $imageModel = new Default_Model_DbTable_Image(); try { $uploadedSmallImage = $imageModel->saveImage($form->getElement(self::IMAGE_SMALL_UPLOAD)); $values['image_small'] = $uploadedSmallImage ? $uploadedSmallImage : $values['image_small']; } catch (Exception $e) { Zend_Registry::get('logger')->err(__METHOD__ . ' - ERROR upload productPicture - ' . print_r($e, true)); } // save changes - $projectData->setFromArray($values); + $projectModel->updateProject($this->_projectId, $values); //update the gallery pics $pictureSources = array_merge($values['gallery']['online_picture'], $this->saveGalleryPics($form->gallery->upload->upload_picture)); $projectModel->updateGalleryPictures($this->_projectId, $pictureSources); //If there is no Logo, we take the 1. gallery pic if (!isset($projectData->image_small) || $projectData->image_small == '') { $projectData->image_small = $pictureSources[0]; } //20180219 ronald: we set the changed_at only by new files or new updates //$projectData->changed_at = new Zend_Db_Expr('NOW()'); $projectData->save(); $modelTags->processTagProductOriginal($this->_projectId,$values['is_original']); if($values['tagsuser']) { $modelTags->processTagsUser($this->_projectId,implode(',',$values['tagsuser']), Default_Model_Tags::TAG_TYPE_PROJECT); }else { $modelTags->processTagsUser($this->_projectId,null, Default_Model_Tags::TAG_TYPE_PROJECT); } $activityLog = new Default_Model_ActivityLog(); $activityLog->writeActivityLog($this->_projectId, $this->_authMember->member_id, Default_Model_ActivityLog::PROJECT_EDITED, $projectData->toArray()); // ppload $this->processPploadId($projectData); try { if (100 < $this->_authMember->roleId) { if (Default_Model_Spam::hasSpamMarkers($projectData->toArray())) { $tableReportComments = new Default_Model_DbTable_ReportProducts(); $tableReportComments->save(array('project_id' => $projectData->project_id, 'reported_by' => 24, 'text' => "System: automatic spam detection on product edit")); } Default_Model_DbTable_SuspicionLog::logProject($projectData, $this->_authMember, $this->getRequest()); } } catch (Zend_Exception $e) { Zend_Registry::get('logger')->err($e->getMessage()); } $helperBuildMemberUrl = new Default_View_Helper_BuildMemberUrl(); $this->redirect($helperBuildMemberUrl->buildMemberUrl($member->username, 'products')); } public function getupdatesajaxAction() { $this->view->authMember = $this->_authMember; $tableProject = new Default_Model_ProjectUpdates(); $updates = $tableProject->fetchProjectUpdates($this->_projectId); foreach ($updates as $key => $update) { $updates[$key]['title'] = Default_Model_HtmlPurify::purify($update['title']); $updates[$key]['text'] = Default_Model_BBCode::renderHtml(Default_Model_HtmlPurify::purify(htmlentities($update['text'], ENT_QUOTES | ENT_IGNORE))); $updates[$key]['raw_title'] = $update['title']; $updates[$key]['raw_text'] = $update['text']; } $result['status'] = 'success'; $result['ResultSize'] = count($updates); $result['updates'] = $updates; $this->_helper->json($result); } public function saveupdateajaxAction() { $filter = new Zend_Filter_Input( array( '*' => 'StringTrim' ), array( '*' => array(), 'title' => array( new Zend_Validate_StringLength(array('min' => 3, 'max' => 200)), 'presence' => 'required', 'allowEmpty' => false ), 'text' => array( new Zend_Validate_StringLength(array('min' => 3, 'max' => 16383)), 'presence' => 'required', 'allowEmpty' => false ), 'update_id' => array('digits', 'allowEmpty' => true) ), $this->getAllParams(), array('allowEmpty' => true)); if ($filter->hasInvalid() OR $filter->hasMissing() OR $filter->hasUnknown()) { $result['status'] = 'error'; $result['messages'] = $filter->getMessages(); $result['update_id'] = null; $this->_helper->json($result); } $update_id = $filter->getEscaped('update_id'); $tableProjectUpdates = new Default_Model_ProjectUpdates(); //Save update if (!empty($update_id)) { //Update old update $updateArray = array(); $updateArray['title'] = $filter->getUnescaped('title'); $updateArray['text'] = $filter->getUnescaped('text'); $updateArray['changed_at'] = new Zend_Db_Expr('Now()'); $countUpdated = $tableProjectUpdates->update($updateArray, 'project_update_id = ' . $update_id); } else { //Add new update $updateArray = array(); $updateArray['title'] = $filter->getUnescaped('title'); $updateArray['text'] = $filter->getUnescaped('text'); $updateArray['public'] = 1; $updateArray['project_id'] = $this->_projectId; $updateArray['member_id'] = $this->_authMember->member_id; $updateArray['created_at'] = new Zend_Db_Expr('Now()'); $updateArray['changed_at'] = new Zend_Db_Expr('Now()'); $rowset = $tableProjectUpdates->save($updateArray); $update_id = $rowset->project_update_id; //20180219 ronald: we set the changed_at only by new files or new updates $projectTable = new Default_Model_Project(); $projectUpdateRow = $projectTable->find($this->_projectId)->current(); if (count($projectUpdateRow) == 1) { $projectUpdateRow->changed_at = new Zend_Db_Expr('NOW()'); $projectUpdateRow->save(); } } $result['status'] = 'success'; $result['update_id'] = $update_id; $this->_helper->json($result); } public function deleteupdateajaxAction() { $this->view->authMember = $this->_authMember; $tableProject = new Default_Model_ProjectUpdates(); $params = $this->getAllParams(); $project_update_id = $params['update_id']; $updateArray = array(); $updateArray['public'] = 0; $updateArray['changed_at'] = new Zend_Db_Expr('Now()'); $tableProject->update($updateArray, 'project_update_id = ' . $project_update_id); $result['status'] = 'success'; $result['update_id'] = $project_update_id; $this->_helper->json($result); } public function updatesAction() { $this->view->authMember = $this->_authMember; $tableProject = new Default_Model_Project(); $this->view->product = $tableProject->fetchProductInfo($this->_projectId); if (false === isset($this->view->product)) { throw new Zend_Controller_Action_Exception('This page does not exist', 404); } $this->view->relatedProducts = $tableProject->fetchSimilarProjects($this->view->product, 6); $this->view->supporter = $tableProject->fetchProjectSupporter($this->_projectId); $this->view->product_views = $tableProject->fetchProjectViews($this->_projectId); $modelPlings = new Default_Model_DbTable_Plings(); $this->view->comments = $modelPlings->getCommentsForProject($this->_projectId, 10); $tableMember = new Default_Model_Member(); $this->view->member = $tableMember->fetchMemberData($this->view->product->member_id); $this->view->updates = $tableProject->fetchProjectUpdates($this->_projectId); $tablePageViews = new Default_Model_DbTable_StatPageViews(); $tablePageViews->savePageView($this->_projectId, $this->getRequest()->getClientIp(), $this->_authMember->member_id); } public function updateAction() { $this->_helper->layout()->setLayout('flat_ui'); $this->view->headScript()->setFile(''); $this->view->headLink()->setStylesheet(''); $this->_helper->viewRenderer('add'); $form = new Default_Form_ProjectUpdate(); $projectTable = new Default_Model_Project(); $projectData = null; $projectUpdateId = (int)$this->getParam('upid'); $this->view->member = $this->_authMember; $this->view->title = 'Add an update for your product'; $activityLogType = Default_Model_ActivityLog::PROJECT_ITEM_CREATED; if (false === empty($projectUpdateId)) { $this->view->title = 'Edit an product update'; $projectData = $projectTable->find($projectUpdateId)->current(); $form->populate($projectData->toArray()); $form->getElement('upid')->setValue($projectUpdateId); $activityLogType = Default_Model_ActivityLog::PROJECT_ITEM_EDITED; } $this->view->form = $form; if ($this->_request->isGet()) { return; } if (isset($_POST['cancel'])) { // user cancel function $this->_redirect('/member/' . $this->_authMember->member_id . '/news/'); } if (false === $form->isValid($_POST)) { // form not valid $this->view->form = $form; $this->view->error = 1; return; } $values = $form->getValues(); $projectUpdateRow = $projectTable->find($values['upid'])->current(); if (count($projectUpdateRow) == 0) { $projectUpdateRow = $projectTable->createRow($values); $projectUpdateRow->project_id = $values['upid']; $projectUpdateRow->created_at = new Zend_Db_Expr('NOW()'); $projectUpdateRow->start_date = new Zend_Db_Expr('NOW()'); $projectUpdateRow->member_id = $this->_authMember->member_id; $projectUpdateRow->creator_id = $this->_authMember->member_id; $projectUpdateRow->status = Default_Model_Project::PROJECT_ACTIVE; $projectUpdateRow->type_id = 2; $projectUpdateRow->pid = $this->_projectId; } else { $projectUpdateRow->setFromArray($values); //20180219 ronald: we set the changed_at only by new files or new updates //$projectUpdateRow->changed_at = new Zend_Db_Expr('NOW()'); } $lastId = $projectUpdateRow->save(); //New Project in Session, for AuthValidation (owner) $this->_auth->getIdentity()->projects[$lastId] = array('project_id' => $lastId); $tableProduct = new Default_Model_Project(); $product = $tableProduct->find($this->_projectId)->current(); $activityLogValues = $projectUpdateRow->toArray(); $activityLogValues['image_small'] = $product->image_small; $activityLog = new Default_Model_ActivityLog(); //$activityLog->writeActivityLog($lastId, $projectUpdateRow->member_id, $activityLogType, $activityLogValues); $activityLog->writeActivityLog($lastId, $this->_authMember->member_id, $activityLogType, $activityLogValues); $helperBuildProductUrl = new Default_View_Helper_BuildProductUrl(); $urlProjectShow = $helperBuildProductUrl->buildProductUrl($this->_projectId); $this->redirect($urlProjectShow); } public function previewAction() { $this->view->authMember = $this->_authMember; $form = new Default_Form_ProjectConfirm(); if ($this->_request->isGet()) { $form->populate(get_object_vars($this->_authMember)); $this->view->form = $form; $this->fetchDataForIndexView(); $this->view->preview = $this->view->render('product/index.phtml'); return; } if (isset($_POST['save'])) { $projectTable = new Default_Model_Project(); $projectTable->setStatus(Default_Model_Project::PROJECT_INACTIVE, $this->_projectId); //todo: maybe we have to delete the project data from database otherwise we produce many zombies $this->redirect('/member/' . $this->_authMember->member_id . '/products/'); } if (isset($_POST['back'])) { $helperBuildProductUrl = new Default_View_Helper_BuildProductUrl(); $this->redirect($helperBuildProductUrl->buildProductUrl($this->_projectId, 'edit')); } if (false === $form->isValid($_POST)) { // form not valid $this->view->form = $form; $this->fetchDataForIndexView(); $this->view->preview = $this->view->render('product/index.phtml'); $this->view->error = 1; return; } $projectTable = new Default_Model_Project(); $projectTable->setStatus(Default_Model_Project::PROJECT_ACTIVE, $this->_projectId); // add to search index $modelProject = new Default_Model_Project(); $productInfo = $modelProject->fetchProductInfo($this->_projectId); $modelSearch = new Default_Model_Search_Lucene(); $modelSearch->addDocument($productInfo->toArray()); $this->redirect('/member/' . $this->_authMember->member_id . '/products/'); } protected function fetchDataForIndexView() { $tableProject = new Default_Model_Project(); $this->view->product = $tableProject->fetchProductInfo($this->_projectId); if (false === isset($this->view->product)) { throw new Zend_Controller_Action_Exception('This page does not exist', 404); } $desc = $this->view->product->description; $newDesc = $this->bbcode2html($desc); $this->view->product->description = $newDesc; // switch off temporally 02.05.2017 //$this->view->supporting = $tableProject->fetchProjectSupporterWithPlings($this->_projectId); //$orgUpdates = $tableProjectUpdates->fetchLastProjectUpdate($this->_projectId); $tableProjectUpdates = new Default_Model_ProjectUpdates(); $orgUpdates = $tableProjectUpdates->fetchProjectUpdates($this->_projectId); $newUpdates = array(); foreach ($orgUpdates as $update) { $desc = $update['text']; $newDesc = $this->bbcode2html($desc); $update['text'] = $newDesc; $newUpdates[] = $update; } $this->view->updates = $newUpdates; // switch off temporally 02.05.2017 //$this->view->supporter = $tableProject->fetchProjectSupporter($this->_projectId); $this->view->galleryPictures = $tableProject->getGalleryPictureSources($this->_projectId); $this->view->product_views = $tableProject->fetchProjectViews($this->_projectId); $helperFetchCategory = new Default_View_Helper_CatTitle(); $helperFetchCatParent = new Default_View_Helper_CatParent(); $this->view->catId = $this->view->product->project_category_id; $this->view->catTitle = $helperFetchCategory->catTitle($this->view->product->project_category_id); $this->view->catParentId = $helperFetchCatParent->getCatParentId(array('project_category_id' => $this->view->product->project_category_id)); if ($this->view->catParentId) { $this->view->catParentTitle = $helperFetchCategory->catTitle($this->view->catParentId); } $AuthCodeExist = new Local_Verification_WebsiteProject(); $this->view->websiteAuthCode = $AuthCodeExist->generateAuthCode(stripslashes($this->view->product->link_1)); // switch off temporally 02.05.2017 //$modelPlings = new Default_Model_DbTable_Plings(); //$this->view->plings = $modelPlings->getDonationsForProject($this->_projectId, 10); $tableMember = new Default_Model_Member(); $this->view->member = $tableMember->fetchMemberData($this->view->product->member_id); $this->view->more_products = $tableProject->fetchMoreProjects($this->view->product, 8); $this->view->more_products_otheruser = $tableProject->fetchMoreProjectsOfOtherUsr($this->view->product, 8); $widgetDefaultModel = new Default_Model_DbTable_ProjectWidgetDefault(); $widgetDefault = $widgetDefaultModel->fetchConfig($this->_projectId); $widgetDefault->text->headline = $this->view->product->title; //$widgetDefault->amounts->current = $this->view->product->amount_received; $widgetDefault->amounts->goal = $this->view->product->amount; $widgetDefault->project = $this->_projectId; $this->view->widgetConfig = $widgetDefault; $helperBuildProductUrl = new Default_View_Helper_BuildProductUrl(); $this->view->permaLink = $helperBuildProductUrl->buildProductUrl($this->_projectId, null, null, true); $this->view->urlPay = $helperBuildProductUrl->buildProductUrl($this->_projectId, 'pay'); $referrerUrl = $this->readExploreUrlFromReferrer(); if (false === empty($referrerUrl)) { $this->view->referrerUrl = $referrerUrl; } } /** * transforms a string with bbcode markup into html * * @param string $txt * @param bool $nl2br * * @return string */ private function bbcode2html($txt, $nl2br = true, $forcecolor = '') { if (!empty($forcecolor)) { $fc = ' style="color:' . $forcecolor . ';"'; } else { $fc = ''; } $newtxt = htmlspecialchars($txt); if ($nl2br) { $newtxt = nl2br($newtxt); } $patterns = array( '`\[b\](.+?)\[/b\]`is', '`\[i\](.+?)\[/i\]`is', '`\[u\](.+?)\[/u\]`is', '`\[li\](.+?)\[/li\]`is', '`\[strike\](.+?)\[/strike\]`is', '`\[url\]([a-z0-9]+?://){1}([\w\-]+\.([\w\-]+\.)*[\w]+(:[0-9]+)?(/[^ \"\n\r\t<]*)?)\[/url\]`si', '`\[quote\](.+?)\[/quote\]`is', '`\[indent](.+?)\[/indent\]`is' ); $replaces = array( 'There was an error. Please check your input and try again.
'); return; } $this->view->searchText = $filterInput->getEscaped('projectSearchText'); $this->view->page = $filterInput->getEscaped('page'); $this->view->searchField = $filterInput->getEscaped('f'); $this->view->pci = $filterInput->getEscaped('pci'); $this->view->ls = $filterInput->getEscaped('ls'); $this->view->t = $filterInput->getEscaped('t'); $this->view->pkg = $filterInput->getEscaped('pkg'); $this->view->arch = $filterInput->getEscaped('arch'); $this->view->lic = $filterInput->getEscaped('lic'); $this->view->store = $this->getParam('domain_store_id'); } /** * @param $memberId * * @throws Zend_Db_Table_Exception */ protected function setViewDataForMyProducts($memberId) { $tableMember = new Default_Model_Member(); $this->view->member = $tableMember->find($memberId)->current(); $tableProduct = new Default_Model_Project(); $this->view->products = $tableProduct->fetchAllProjectsForMember($memberId); } protected function _initResponseHeader() { $duration = 1800; // in seconds $expires = gmdate("D, d M Y H:i:s", time() + $duration) . " GMT"; $this->getResponse()->setHeader('X-FRAME-OPTIONS', 'ALLOWALL', true)// ->setHeader('Last-Modified', $modifiedTime, true) ->setHeader('Expires', $expires, true)->setHeader('Pragma', 'no-cache', true) ->setHeader('Cache-Control', 'private, no-cache, must-revalidate', true) ; } /** * @param $hits * * @return array */ protected function generateProjectsArrayForView($hits) { $viewArray = array(); $helperBuildProductUrl = new Default_View_Helper_BuildProductUrl(); /** @var $hit Zend_Search_Lucene_Search_QueryHit */ foreach ($hits as $hit) { $project = $hit->getDocument(); if (null != $project->username) { $isUpdate = ($project->type_id == 2); if ($isUpdate) { $showUrl = $helperBuildProductUrl->buildProductUrl($project->pid) . '#anker_' . $project->project_id; $plingUrl = $helperBuildProductUrl->buildProductUrl($project->pid, 'pling'); } else { $showUrl = $helperBuildProductUrl->buildProductUrl($project->project_id); $plingUrl = $helperBuildProductUrl->buildProductUrl($project->project_id, 'pling'); } $projectArr = array( 'score' => $hit->score, 'id' => $project->project_id, 'type_id' => $project->type_id, 'title' => $project->title, 'description' => $project->description, 'image' => $project->image_small, 'plings' => 0, 'urlGoal' => $showUrl, 'urlPling' => $plingUrl, 'showUrlPling' => ($project->paypal_mail != null), 'member' => array( 'name' => $project->username, 'url' => 'member/' . $project->member_id, 'image' => $project->profile_image_url, 'id' => $project->member_id ) ); $viewArray[] = $projectArr; } } return $viewArray; } protected function setLayout() { $layoutName = 'flat_ui_template'; $storeConfig = Zend_Registry::isRegistered('store_config') ? Zend_Registry::get('store_config') : null; if($storeConfig && $storeConfig->layout_pagedetail) { $this->_helper->layout()->setLayout($storeConfig->layout_pagedetail); }else{ $this->_helper->layout()->setLayout($layoutName); } } private function fetchGitlabProject($gitProjectId) { $gitlab = new Default_Model_Ocs_Gitlab(); try { $gitProject = $gitlab->getProject($gitProjectId); } catch (Exception $exc) { //Project is gone $modelProject = new Default_Model_Project(); $modelProject->updateProject($this->_projectId, array('is_gitlab_project' => 0, 'gitlab_project_id' => null, 'show_gitlab_project_issues' => 0, 'use_gitlab_project_readme' => 0)); $gitProject = null; } return $gitProject; } private function fetchGitlabProjectIssues($gitProjectId) { $gitlab = new Default_Model_Ocs_Gitlab(); try { $gitProjectIssues = $gitlab->getProjectIssues($gitProjectId); } catch (Exception $exc) { //Project is gone $modelProject = new Default_Model_Project(); $modelProject->updateProject($this->_projectId, array('is_gitlab_project' => 0, 'gitlab_project_id' => null, 'show_gitlab_project_issues' => 0, 'use_gitlab_project_readme' => 0)); $gitProjectIssues = null; } return $gitProjectIssues; } public function startvideoajaxAction() { $this->_helper->layout()->disableLayout(); $collection_id = null; $file_id = null; $memberId = $this->_authMember->member_id; if($this->hasParam('collection_id') && $this->hasParam('file_id')) { $collection_id = $this->getParam('collection_id'); $file_id = $this->getParam('file_id'); $id = null; //Log media view try { $mediaviewsTable = new Default_Model_DbTable_MediaViews(); $id = $mediaviewsTable->getNewId(); $data = array('media_view_id' => $id, 'media_view_type_id' => $mediaviewsTable::MEDIA_TYPE_VIDEO, 'project_id' => $this->_projectId, 'collection_id' => $collection_id, 'file_id' => $file_id, 'start_timestamp' => new Zend_Db_Expr ('Now()'), 'ip' => $this->getRealIpAddr(), 'referer' => $this->getReferer()); if(!empty($memberId)) { $data['member_id'] = $memberId; } $data['source'] = 'OCS-Webserver'; $mediaviewsTable->createRow($data)->save(); } catch (Exception $exc) { //echo $exc->getTraceAsString(); $errorLog = Zend_Registry::get('logger'); $errorLog->err(__METHOD__ . ' - ' . $exc->getMessage() . ' ---------- ' . PHP_EOL); } $this->_helper->json(array('status' => 'success', 'MediaViewId' => $id)); return; } $this->_helper->json(array('status' => 'error')); } public function stopvideoajaxAction() { $this->_helper->layout()->disableLayout(); $view_id = null; if($this->hasParam('media_view_id')) { $view_id = $this->getParam('media_view_id'); //Log media view stop try { $mediaviewsTable = new Default_Model_DbTable_MediaViews(); $data = array('stop_timestamp' => new Zend_Db_Expr ('Now()')); $mediaviewsTable->update($data, 'media_view_id = '. $view_id); } catch (Exception $exc) { //echo $exc->getTraceAsString(); $errorLog = Zend_Registry::get('logger'); $errorLog->err(__METHOD__ . ' - ' . $exc->getMessage() . ' ---------- ' . PHP_EOL); } $this->_helper->json(array('status' => 'success', 'MediaViewId' => $view_id)); return; } $this->_helper->json(array('status' => 'error')); } function getRealIpAddr() { if (!empty($_SERVER['HTTP_CLIENT_IP'])) //check ip from share internet { $ip=$_SERVER['HTTP_CLIENT_IP']; } elseif (!empty($_SERVER['HTTP_X_FORWARDED_FOR'])) //to check ip is pass from proxy { $ip=$_SERVER['HTTP_X_FORWARDED_FOR']; } else { $ip=$_SERVER['REMOTE_ADDR']; } return $ip; } function getReferer() { $referer = null; if (!empty($_SERVER['HTTP_REFERER'])) { $referer = $_SERVER['HTTP_REFERER']; } return $referer; } } diff --git a/application/modules/default/forms/Product.php b/application/modules/default/forms/Product.php index 5447cc8af..7d7d0425b 100644 --- a/application/modules/default/forms/Product.php +++ b/application/modules/default/forms/Product.php @@ -1,728 +1,718 @@ . **/ class Default_Form_Product extends Zend_Form { protected $onlineGalleryImageSources = array(); private $member_id = null; public function __construct($options = null) { if (isset($options['pictures'])) { $this->onlineGalleryImageSources = $options['pictures']; } if (isset($options['member_id'])) { $this->member_id = $options['member_id']; } parent::__construct($options); } /** * @param $sources array */ public function setOnlineGalleryImageSources($sources) { $this->onlineGalleryImageSources = $sources; $this->init(); } public function init() { $this->setAction(''); $this->setAttrib('enctype', 'multipart/form-data'); $this->addPrefixPath('Default_Form_Element', APPLICATION_PATH . '/modules/default/forms/elements/', Zend_Form::ELEMENT); $this->addElement($this->getTitleElement()) ->addElement($this->getCategoryIdElement()) ->addElement($this->getDescriptionElement()) ->addElement($this->getVersionElement()) ->addElement($this->getSmallImageElement()) ->addElement($this->getImageUploadElement()) - // ->addElement($this->getBigImageElement()) - // ->addElement($this->getBigImageUploadElement()) ->addSubForm($this->getGalleryElement(), 'gallery') - // ->addElement($this->getAmountElement()) - // ->addElement($this->getAmountPeriodElement()) ->addElement($this->getEmbedCodeElement()) ->addElement($this->getProjectHomepageElement()) ->addElement($this->getSourceElement()) ->addElement($this->getFacebookElement()) ->addElement($this->getTwitterElement()) ->addElement($this->getGoogleElement()) ->addElement($this->getTagElement()) ->addElement($this->getTagUserElement()) ->addElement($this->getHiddenProjectId()) ->addElement($this->getSubmitElement()) ->addElement($this->getCancelElement()) ->addElement($this->getLicenseIdElement()) ->addElement($this->getIsOriginal()) ->addElement($this->getIsGitlab()) ->addElement($this->getGitlabProjectId()) ->addElement($this->getShowGitlabProjectIssues()) ->addElement($this->getUseGitlabProjectReadme()) - - //->addElement($this->getCCAttribution()) - //->addElement($this->getCCComercial()) - //->addElement($this->getCCDerivateWorks()) - //->addElement($this->getCCShareAlike()) - //->addElement($this->getCCLicense()) ; } private function getTitleElement() { // $validatorRegEx = new Zend_Validate_Regex(array('pattern' => "/^[ \/\[\]\.\-_A-Za-z0-9'\pL]{1,}$/iu")); // with unicode character class $validatorRegEx = new Zend_Validate_Regex(array('pattern' => "/^[ \/\[\]\.\-_A-Za-z0-9']{1,}$/iu")); $validatorRegEx->setMessages(array(Zend_Validate_Regex::NOT_MATCH => "'%value%' is not valid. Please use only alphanumeric characters or /, [, ], -, _, ' ")); return $this->createElement('text', 'title') ->setRequired(true) ->addValidators(array( array('StringLength', true, array(4, 60)), $validatorRegEx )) ->setFilters(array('StringTrim')) ->setDecorators(array( array( 'ViewScript', array( 'viewScript' => 'product/viewscripts/input_title.phtml', 'placement' => false ) ) )) ; } private function getCategoryIdElement() { $validatorCategory = new Default_Form_Validator_Category(); return $this->createElement('number', 'project_category_id', array()) ->setRequired(true) ->addValidator('Digits') ->addValidator($validatorCategory) ->addFilter('Digits') ->setDecorators(array( array( 'ViewScript', array( 'viewScript' => 'product/viewscripts/input_cat_id.phtml', 'placement' => false ) ) )) ; } private function getDescriptionElement() { return $this->createElement('textarea', 'description', array('cols' => 30, 'rows' => 9)) ->setRequired(true) ->setFilters(array('StringTrim')) ->setDecorators(array( array( 'ViewScript', array( 'viewScript' => 'product/viewscripts/input_description.phtml', 'placement' => false ) ) )) ; } private function getVersionElement() { return $this->createElement('text', 'version') ->setRequired(false) ->addValidators(array( array('StringLength', false, array(0, 50)), )) ->setFilters(array('StringTrim')) ->setDecorators(array( array( 'ViewScript', array( 'viewScript' => 'product/viewscripts/input_version.phtml', 'placement' => false ) ) )) ; } private function getSmallImageElement() { return $this->createElement('hidden', 'image_small') ->setFilters(array('StringTrim')) ->addValidators(array( array( 'Regex', false, array('/^[A-Za-z0-9.\/_-]{1,}$/i') ) )) ->setDecorators(array( array( 'ViewScript', array( 'viewScript' => 'product/viewscripts/input_image_small.phtml', 'placement' => false ) ) )) ; } private function getImageUploadElement() { $modelImage = new Default_Model_DbTable_Image(); return $this->createElement('file', 'image_small_upload') ->setDisableLoadDefaultDecorators(true) ->setValueDisabled(true) ->setTransferAdapter(new Local_File_Transfer_Adapter_Http()) ->setRequired(false) ->setMaxFileSize(2097152) ->addValidator('Count', false, 1) ->addValidator('Size', false, array('min' => '500B', 'max' => '2MB')) ->addValidator('Extension', false, $modelImage->getAllowedFileExtension()) ->addValidator('ImageSize', false, array( 'minwidth' => 20, 'maxwidth' => 2000, 'minheight' => 20, 'maxheight' => 2000 )) ->addValidator('MimeType', false, $modelImage->getAllowedMimeTypes()) ->setDecorators(array( array('File' => new Local_Form_Decorator_File()), array( 'ViewScript', array( 'viewScript' => 'product/viewscripts/input_image_small_upload.phtml', 'placement' => false ) ) )) ; } private function getGalleryElement() { $gallerySubform = new Default_Form_GallerySubForm(array('pictures' => $this->onlineGalleryImageSources)); $gallerySubform->setMaxGalleryPics(5); return $gallerySubform; } private function getEmbedCodeElement() { return $this->createElement('textarea', 'embed_code', array('cols' => 30, 'rows' => 3)) ->setRequired(false) ->setFilters(array('StringTrim')) ->setDecorators(array( array( 'ViewScript', array( 'viewScript' => 'product/viewscripts/input_embedcode.phtml', 'placement' => false ) ) )) ; } private function getProjectHomepageElement() { return $this->createElement('text', 'link_1', array()) ->setRequired(false) ->setFilters(array('StringTrim')) ->addPrefixPath('Local_Validate', 'Local/Validate', Zend_Form_Element::VALIDATE) ->addValidator('PartialUrl') ->setDecorators(array( array( 'ViewScript', array( 'viewScript' => 'product/viewscripts/input_link.phtml', 'placement' => false ) ) )) ; } private function getSourceElement() { return $this->createElement('text', 'source_url', array()) ->setRequired(false) ->setFilters(array('StringTrim')) ->addPrefixPath('Local_Validate', 'Local/Validate', Zend_Form_Element::VALIDATE) ->addValidator('PartialUrl') ->setDecorators(array( array( 'ViewScript', array( 'viewScript' => 'product/viewscripts/input_source_url.phtml', 'placement' => false ) ) )) ; } private function getFacebookElement() { return $this->createElement('text', 'facebook_code', array()) ->setRequired(false) ->setFilters(array('StringTrim')) ->addPrefixPath('Local_Validate', 'Local/Validate', Zend_Form_Element::VALIDATE) ->addValidator('PartialUrl') ->setDecorators(array( array( 'ViewScript', array( 'viewScript' => 'product/viewscripts/input_facebook.phtml', 'placement' => false ) ) )) ; } private function getTwitterElement() { return $this->createElement('text', 'twitter_code', array()) ->setRequired(false) ->setFilters(array('StringTrim')) ->addPrefixPath('Local_Validate', 'Local/Validate', Zend_Form_Element::VALIDATE) ->addValidator('PartialUrl') ->setDecorators(array( array( 'ViewScript', array( 'viewScript' => 'product/viewscripts/input_twitter.phtml', 'placement' => false ) ) )) ; } private function getGoogleElement() { return $this->createElement('text', 'google_code', array()) ->setRequired(false) ->setFilters(array('StringTrim')) ->addPrefixPath('Local_Validate', 'Local/Validate', Zend_Form_Element::VALIDATE) ->addValidator('PartialUrl') ->setDecorators(array( array( 'ViewScript', array( 'viewScript' => 'product/viewscripts/input_google.phtml', 'placement' => false ) ) )) ; } private function getTagElement() { $element = new Zend_Form_Element_Multiselect('tags', array('registerInArrayValidator' => false)); return $element->setFilters(array('StringTrim'))->setDecorators(array( array( 'ViewScript', array( 'viewScript' => 'product/viewscripts/input_tags_multiselect.phtml', 'placement' => false ) ) )) ; } private function getTagUserElement() { $element = new Zend_Form_Element_Multiselect('tagsuser', array('registerInArrayValidator' => false)); return $element->setFilters(array('StringTrim'))->setDecorators(array( array( 'ViewScript', array( 'viewScript' => 'product/viewscripts/input_tags_user.phtml', 'placement' => false ) ) )) ; } private function getHiddenProjectId() { return $this->createElement('hidden', 'project_id')->setFilters(array('StringTrim'))->addValidators(array('Digits')) ->setDecorators(array( array( 'ViewScript', array( 'viewScript' => 'product/viewscripts/input_hidden.phtml', 'placement' => false ) ) )) ; } private function getSubmitElement() { $submit = $this->createElement('button', 'preview')->setDecorators(array( 'ViewHelper' )) ; $submit->setLabel('Preview'); $submit->setAttrib('type', 'submit'); return $submit; } private function getCancelElement() { $cancel = $this->createElement('button', 'cancel')->setDecorators(array( 'ViewHelper' )) ; $cancel->setLabel('Cancel'); $cancel->setAttrib('type', 'submit'); return $cancel; } private function getLicenseIdElement() { //$element = new Zend_Form_Element_Multiselect('project_license_id', array('registerInArrayValidator' => false)); $element = new Zend_Form_Element_Select('license_tag_id', array('multiple' => false)); $element->setIsArray(true); $tagTable = new Default_Model_DbTable_Tags(); $options = $tagTable->fetchLicenseTagsForSelect(); return $element->setFilters(array('StringTrim'))->setMultiOptions($options)->setDecorators(array( array( 'ViewScript', array( 'viewScript' => 'product/viewscripts/input_select_license.phtml', 'placement' => false ) ) )) ; } private function getIsOriginal() { $element = new Zend_Form_Element_Checkbox('is_original'); return $element->setOptions(array( 'label' => ' Product original ', 'use_hidden_element' => false, 'checked_value' => 1, 'unchecked_value' => 0 )); } private function getIsGitlab() { $element = new Zend_Form_Element_Checkbox('is_gitlab_project'); return $element->setOptions(array( 'label' => ' Git-Project ', 'use_hidden_element' => false, 'checked_value' => 1, 'unchecked_value' => 0 )); } private function getGitlabProjectId() { $element = new Zend_Form_Element_Select('gitlab_project_id', array('multiple' => false)); $element->setIsArray(true); $gitlab = new Default_Model_Ocs_Gitlab(); $optionArray = array(); if ($this->member_id) { $memberTable = new Default_Model_Member(); $member = $memberTable->fetchMemberData($this->member_id); $gitlab_user_id = null; if(!empty($member->gitlab_user_id)) { //get gitlab user id from db $gitlab_user_id = $member->gitlab_user_id; } else { //get gitlab user id from gitlab API and save in DB $gitUser = $gitlab->getUserWithName($member->username); if ($gitUser && null != $gitUser) { $gitlab_user_id = $gitUser['id']; $memberTableExternal = new Default_Model_DbTable_MemberExternalId(); $memberTableExternal->updateGitlabUserId($this->member_id, $gitlab_user_id); } } if ($gitlab_user_id && null != $gitlab_user_id) { try { //now get his projects $gitProjects = $gitlab->getUserProjects($gitlab_user_id); foreach ($gitProjects as $proj) { $optionArray[$proj['id']] = $proj['name']; } } catch (Exception $exc) { //Error getting USerProjects, } } } return $element->setFilters(array('StringTrim'))->setMultiOptions($optionArray)->setDecorators(array( array( 'ViewScript', array( 'viewScript' => 'product/viewscripts/input_gitlab_project_id.phtml', 'placement' => false ) ) )) ; } private function getShowGitlabProjectIssues() { $element = new Zend_Form_Element_Checkbox('show_gitlab_project_issues'); return $element->setOptions(array( 'label' => ' Git-Issues ', 'use_hidden_element' => false, 'checked_value' => 1, 'unchecked_value' => 0 )); } private function getUseGitlabProjectReadme() { $element = new Zend_Form_Element_Checkbox('use_gitlab_project_readme'); return $element->setOptions(array( 'label' => 'README.md', 'use_hidden_element' => false, 'checked_value' => 1, 'unchecked_value' => 0 )); } public function initSubCatElement($projectCatId) { if (false === isset($projectCatId)) { return; } $tableSubCategory = new Default_Model_SubCategory(); $subcategories = $tableSubCategory->fetchAllSubCategories($projectCatId); $this->getElement('project_subcategory_id')->setMultiOptions($subcategories); } public function initSubSubCatElement($projectSubCatId) { if (false === isset($projectCatId)) { return; } $modelSubSubCategories = new Default_Model_SubSubCategory(); $subSubCategories = $modelSubSubCategories->fetchAllSubCategories($projectSubCatId); $this->getElement('project_subcategory_id')->setMultiOptions($subSubCategories); } /** * Validate the form * * @param array $data * @param null $project_id * * @return bool * @throws Zend_Exception * @throws Zend_Form_Exception */ public function isValid($data, $project_id = null) { $sqlExclude = 'status > ' . Default_Model_DbTable_Project::PROJECT_DELETED; if (isset($project_id)) { $db = Zend_Registry::get('db'); $sqlExclude .= $db->quoteInto(' AND project_id <> ?', $project_id, 'INTEGER'); } /* $checkTitleExist = new Zend_Validate_Db_NoRecordExists(array( 'table' => 'project', 'field' => 'title', 'exclude' => $sqlExclude )); $checkTitleExist->setMessage('This title already exists.', Zend_Validate_Db_NoRecordExists::ERROR_RECORD_FOUND); $this->getElement('title') ->addValidator($checkTitleExist); */ return parent::isValid($data); } /** * Validate a partial form * * Does not check for required flags. * * @param array $data * * @return boolean */ public function isValidPartial(array $data) { return parent::isValidPartial($data); // TODO: Change the autogenerated stub } private function getAmountElement() { return $this->createElement('number', 'amount', array()) ->setRequired(false) ->addValidator('Digits') ->addFilter('Digits') ->setDecorators(array( array( 'ViewScript', array( 'viewScript' => 'product/viewscripts/input_amount.phtml', 'placement' => false ) ) )) ; } private function getAmountPeriodElement() { return $this->createElement('radio', 'amount_period', array()) ->setRequired(false) ->addMultiOptions(array('yearly' => 'yearly (will run continuously each year)', 'one-time' => 'one-time')) ->setValue('yearly') ->setSeparator(' ') ->setDecorators(array( array( 'ViewScript', array( 'viewScript' => 'product/viewscripts/input_amount_period.phtml', 'placement' => false ) ) )) ; } private function getBigImageElement() { return $this->createElement('hidden', 'image_big') ->setFilters(array('StringTrim')) ->addValidators(array( array( 'Regex', false, array('/^[A-Za-z0-9.\/_-]{1,}$/i') ) )) ->setDecorators(array( array( 'ViewScript', array( 'viewScript' => 'product/viewscripts/input_image_big.phtml', 'placement' => false ) ) )) ; } private function getBigImageUploadElement() { $modelImage = new Default_Model_DbTable_Image(); return $this->createElement('file', 'image_big_upload')->setDisableLoadDefaultDecorators(true) ->setTransferAdapter(new Local_File_Transfer_Adapter_Http())->setRequired(false)->setMaxFileSize(2097152) ->addValidator('Count', false, 1)->addValidator('Size', false, 2097152)->addValidator('FilesSize', false, 2000000) ->addValidator('Extension', false, $modelImage->getAllowedFileExtension())->addValidator('ImageSize', false, array( 'minwidth' => 100, 'maxwidth' => 2000, 'minheight' => 100, 'maxheight' => 1200 ))->addValidator('MimeType', false, $modelImage->getAllowedMimeTypes())->setDecorators(array( array('File' => new Local_Form_Decorator_File()), array( 'ViewScript', array( 'viewScript' => 'product/viewscripts/input_image_big_upload.phtml', 'placement' => false ) ) )) ; } private function getCCAttribution() { return $this->createElement('checkbox', 'by'); } private function getCCComercial() { return $this->createElement('checkbox', 'nc'); } private function getCCDerivateWorks() { return $this->createElement('checkbox', 'nd'); } private function getCCShareAlike() { return $this->createElement('checkbox', 'sa'); } private function getCCLicense() { return $this->createElement('checkbox', 'cc_license'); } } \ No newline at end of file diff --git a/application/modules/default/forms/Register.php b/application/modules/default/forms/Register.php index e4e5a48a1..d6a85bd4a 100644 --- a/application/modules/default/forms/Register.php +++ b/application/modules/default/forms/Register.php @@ -1,146 +1,140 @@ . **/ class Default_Form_Register extends Zend_Form { /** * @throws Zend_Exception * @throws Zend_Form_Exception * @throws Zend_Validate_Exception */ public function init() { $this->setMethod('POST'); $this->setAction('/register/'); $this->addElementPrefixPath('Local', 'Local/'); $this->setAttrib('id', 'registerForm'); $this->setAttrib('class', 'standard-form row-fluid center'); $redir = $this->createElement('hidden', 'redirect')->setDecorators(array('ViewHelper')); $this->addElement($redir); $usernameValidChars = new Zend_Validate_Regex('/^(?=.{4,20}$)(?![-])(?!.*[-]{2})[a-z0-9-]+(?setMessage('This username already exists.', Local_Validate_UsernameExists::EXISTS); $userExistCheck->setMessage('This username already exists.'); $userEmptyCheck = new Zend_Validate_NotEmpty(); $userEmptyCheck->setMessage('RegisterFormUsernameErr', Zend_Validate_NotEmpty::IS_EMPTY); $userNameLength = new Zend_Validate_StringLength(array('min' => 4, 'max' => 20)); $groupNameExists = new Local_Validate_GroupnameExistsInOpenCode(); $fname = $this->createElement('text', 'username') ->setDecorators(array('ViewHelper', 'Errors')) ->setRequired(true) ->addFilter(new Zend_Filter_StringTrim()) ->addFilter(new Zend_Filter_StripNewlines()) ->addValidator($userEmptyCheck, true) ->addValidator($userNameLength, true) ->addValidator($usernameValidChars, true) ->addValidator($userExistCheck, true) ->addValidator($groupNameExists, true) ->setAttrib('placeholder', 'Username (4 chars minimum)') - ->setAttrib('class', 'form-control') - ; + ->setAttrib('class', 'form-control'); $mailValidCheck = new Zend_Validate_EmailAddress(); $mailValidCheck->setMessage('RegisterFormEmailErrNotValid', Zend_Validate_EmailAddress::INVALID) ->setMessage('RegisterFormEmailErrNotValid', Zend_Validate_EmailAddress::INVALID_FORMAT) ->setMessage('RegisterFormEmailErrNotValid', Zend_Validate_EmailAddress::INVALID_LOCAL_PART) ->setMessage("RegisterFormEmailErrWrongHost", Zend_Validate_EmailAddress::INVALID_HOSTNAME) ->setMessage("RegisterFormEmailErrWrongHost2", Zend_Validate_Hostname::INVALID_HOSTNAME) ->setMessage("RegisterFormEmailErrHostLocal", Zend_Validate_Hostname::LOCAL_NAME_NOT_ALLOWED) - ->setOptions(array('domain' => true)) - ; + ->setOptions(array('domain' => true)); $mailExistCheck = new Local_Validate_EmailExists(); $mailExistCheck->setMessage('RegisterFormEmailErrAlreadyRegistered', Local_Validate_EmailExists::EXISTS); $mailEmpty = new Zend_Validate_NotEmpty(); $mailEmpty->setMessage('RegisterFormEmailErrEmpty', Zend_Validate_NotEmpty::IS_EMPTY); $mailValidatorChain = new Zend_Validate(); $mailValidatorChain->addValidator($mailEmpty, true) ->addValidator($mailValidCheck, true) - ->addValidator($mailExistCheck, true) - ; + ->addValidator($mailExistCheck, true); $mail = $this->createElement('text', 'mail') ->setLabel('RegisterFormEmailLabel') ->addValidator($mailEmpty, true) ->addValidator($mailValidCheck, true) ->addValidator($mailExistCheck, true) ->setDecorators(array('ViewHelper', 'Errors')) ->setRequired(true) ->setAttrib('placeholder', 'Email') - ->setAttrib('class', 'form-control') - ; + ->setAttrib('class', 'form-control'); $pass1 = $this->createElement('password', 'password1') ->setLabel('RegisterFormPasswordLabel') ->setRequired(true)//->addErrorMessage('RegisterFormPasswordErr') ->setDecorators(array('ViewHelper', 'Errors')) ->setAttrib('placeholder', 'Password') ->addValidator('stringLength', true, array(6, 200)) ->setAttrib('placeholder', 'Password (6 chars minimum)') - ->setAttrib('class', 'form-control') - ; + ->setAttrib('class', 'form-control'); $pass2 = $this->createElement('password', 'password2') ->setLabel('RegisterFormPassword2Label') ->setRequired(true) ->addErrorMessage('RegisterFormPassword2Err') ->setDecorators(array('ViewHelper', 'Errors')) ->setAttrib('placeholder', 'Confirm Password') - ->setAttrib('class', 'form-control') - ; + ->setAttrib('class', 'form-control'); $passValid = new Local_Validate_PasswordConfirm($pass2->getValue()); $pass1->addValidator($passValid, true); $submit = $this->createElement('button', 'login'); $submit->setLabel('Register'); $submit->setDecorators(array('ViewHelper')); $submit->setAttrib('class', 'btn btn-native btn-min-width'); $submit->setAttrib('type', 'submit'); $this->addElement($fname) ->addElement($mail) ->addElement($pass1) ->addElement($pass2) - ->addElement($submit) - ; + ->addElement($submit); if (APPLICATION_ENV == 'development') { return; } $this->addPrefixPath('Cgsmith\\Form\\Element', APPLICATION_LIB . '/Cgsmith/Form/Element', Zend_Form::ELEMENT); - $this->addElementPrefixPath('Cgsmith\\Validate\\', APPLICATION_LIB . '/Cgsmith/Validate/', Zend_Form_Element::VALIDATE); + $this->addElementPrefixPath('Cgsmith\\Validate\\', APPLICATION_LIB . '/Cgsmith/Validate/', + Zend_Form_Element::VALIDATE); $captcha = $this->createElement('recaptcha', 'g-recaptcha-response', array( 'siteKey' => Zend_Registry::get('config')->recaptcha->sitekey, 'secretKey' => Zend_Registry::get('config')->recaptcha->secretkey, )); $this->addElement($captcha); } } \ No newline at end of file diff --git a/application/modules/default/models/DbTable/Image.php b/application/modules/default/models/DbTable/Image.php index 196092b80..51df047f4 100644 --- a/application/modules/default/models/DbTable/Image.php +++ b/application/modules/default/models/DbTable/Image.php @@ -1,455 +1,456 @@ . **/ class Default_Model_DbTable_Image extends Zend_Db_Table_Abstract { protected $_name = "image"; protected $_fields = array( 'id' => null, 'filename' => null, 'code' => null, 'name' => null, 'member_id' => null, 'model' => null, 'foreign_key' => null, 'foreign_id' => null, 'created' => null ); protected $_allowed = array( 'image/jpeg' => '.jpg', 'image/jpg' => '.jpg', 'image/png' => '.png', 'image/gif' => '.gif', 'application/x-empty' => '.png' ); protected $_allowedFileExtension = array( 'jpg', 'jpeg', 'png', 'gif' ); // protected $_maxsize = array( // 'width' => 1024, // 'height' => 768 // ); protected $_maxsize = array( 'width' => 2000, 'height' => 2000 ); protected $_errorMsg = null; public function getMemberImages($member_id) { $images = $this->select()->where('member_id = ?', $member_id)->query()->fetchAll(); return $images; } public function storeExternalImage($url, $fileExtension = null) { Zend_Registry::get('logger')->debug(__METHOD__ . ' - ' . print_r(func_get_args(), true)); $tmpFileName = $this->storeRemoteImage($url, $fileExtension); if (file_exists(IMAGES_UPLOAD_PATH . 'tmp/' . $tmpFileName)) { $content_type = mime_content_type(IMAGES_UPLOAD_PATH . 'tmp/' . $tmpFileName); $filePath = $this->saveImageOnMediaServer($tmpFileName); $filename = $filePath; $file_info['size'] = filesize(IMAGES_UPLOAD_PATH . '/' . $filename); $this->save(array('code' => $content_type, 'filename' => $filename)); } return $filename; } public function storeRemoteImage($url, $fileExtention = null, &$file_info = null) { //$host = parse_url( $url, PHP_URL_HOST ); //$path = parse_url($url, PHP_URL_PATH); //$query = parse_url($url, PHP_URL_QUERY); //$url = 'http://'.$host.$path.'?'.urlencode($query); $limit = 4194304; #4Mb $filename = md5($url); if ($fileExtention) { $filename .= '.' . $fileExtention; } $file_info = array(); if (file_exists(IMAGES_UPLOAD_PATH . 'tmp/' . $filename)) { // Delete old file. Maybe an updated version is available. if (false == unlink(IMAGES_UPLOAD_PATH . 'tmp/' . $filename)) { throw new Exception('Cannot delete file: ' . IMAGES_UPLOAD_PATH . 'tmp/' . $filename); } } try { #$file = file_get_contents($url, NULL, NULL, -1, $limit); $file = $this->file_get_contents_curl($url); } catch (Exception $e) { $file = null; } if (file_put_contents(IMAGES_UPLOAD_PATH . 'tmp/' . $filename, $file)) { $content_type = $this->_get_mime_content_type(IMAGES_UPLOAD_PATH . 'tmp/' . $filename); if (!in_array($content_type, array_keys($this->_allowed))) { throw new Exception('Format not allowed ' . $content_type . ' for url ' . $url); } touch(IMAGES_UPLOAD_PATH . 'tmp/' . $filename); } else { throw new Exception('Error storing remote image'); } $file_info['size'] = filesize(IMAGES_UPLOAD_PATH . 'tmp/' . $filename); return $filename; } public function file_get_contents_curl($url) { $ch = curl_init(); curl_setopt($ch, CURLOPT_AUTOREFERER, true); curl_setopt($ch, CURLOPT_HEADER, 0); curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); curl_setopt($ch, CURLOPT_URL, $url); curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true); $data = curl_exec($ch); curl_close($ch); return $data; } public function _get_mime_content_type($filename) { if (!function_exists('mime_content_type')) { $mime_types = array( 'txt' => 'text/plain', 'htm' => 'text/html', 'html' => 'text/html', 'php' => 'text/html', 'css' => 'text/css', 'js' => 'application/javascript', 'json' => 'application/json', 'xml' => 'application/xml', 'swf' => 'application/x-shockwave-flash', 'flv' => 'video/x-flv', // images 'png' => 'image/png', 'jpe' => 'image/jpeg', 'jpeg' => 'image/jpeg', 'jpg' => 'image/jpeg', 'gif' => 'image/gif', 'bmp' => 'image/bmp', 'ico' => 'image/vnd.microsoft.icon', 'tiff' => 'image/tiff', 'tif' => 'image/tiff', 'svg' => 'image/svg+xml', 'svgz' => 'image/svg+xml', // archives 'zip' => 'application/zip', 'rar' => 'application/x-rar-compressed', 'exe' => 'application/x-msdownload', 'msi' => 'application/x-msdownload', 'cab' => 'application/vnd.ms-cab-compressed', // audio/video 'mp3' => 'audio/mpeg', 'qt' => 'video/quicktime', 'mov' => 'video/quicktime', // adobe 'pdf' => 'application/pdf', 'psd' => 'image/vnd.adobe.photoshop', 'ai' => 'application/postscript', 'eps' => 'application/postscript', 'ps' => 'application/postscript', // ms office 'doc' => 'application/msword', 'rtf' => 'application/rtf', 'xls' => 'application/vnd.ms-excel', 'ppt' => 'application/vnd.ms-powerpoint', // open office 'odt' => 'application/vnd.oasis.opendocument.text', 'ods' => 'application/vnd.oasis.opendocument.spreadsheet', ); $ext = strtolower(array_pop(explode('.', $filename))); if (array_key_exists($ext, $mime_types)) { return $mime_types[$ext]; } else if (function_exists('finfo_open')) { $finfo = finfo_open(FILEINFO_MIME); $mimetype = finfo_file($finfo, $filename); finfo_close($finfo); return $mimetype; } else { return 'application/octet-stream'; } } else { return mime_content_type($filename); } } public function saveImageOnMediaServer($filePathName) { if (empty($filePathName)) { return null; } $content_type = mime_content_type($filePathName); if (!in_array($content_type, array_keys($this->_allowed))) { throw new Exception('Format not allowed: ' . $content_type . ' for img: ' . $filePathName); } // Generate filename $generatedFilename = $this->_generateFilename($filePathName); $destinationFile = IMAGES_UPLOAD_PATH . $generatedFilename . $this->_allowed[$content_type]; if (copy($filePathName, $destinationFile)) { if (file_exists($filePathName)) { if (false === unlink($filePathName)) { Zend_Registry::get('logger')->warn(__METHOD__ . ' - can not delete temp file: ' . $filePathName); } } Zend_Registry::get('logger')->debug(__METHOD__ . ' - Start upload picture - ' . print_r($destinationFile, true)) ; $srcPathOnMediaServer = $this->sendImageToMediaServer($destinationFile, $content_type); if (file_exists($destinationFile)) { if (false === unlink($destinationFile)) { Zend_Registry::get('logger')->warn(__METHOD__ . ' - can not delete file: ' . $destinationFile); } } if (!$srcPathOnMediaServer) { throw new Exception("Error in upload to CDN-Server. \n Server message:\n" . $this->_errorMsg); } Zend_Registry::get('logger')->debug(__METHOD__ . ' - End upload picture - ' . print_r(IMAGES_UPLOAD_PATH . $srcPathOnMediaServer, true)) ; return $srcPathOnMediaServer; } } private function _generateFilename($filePathName) { return sha1_file($filePathName); } /** * @param $fullFilePath * @param $mimeType * * @return string + * @throws Zend_Exception + * @throws Zend_Http_Client_Exception + * @throws Zend_Uri_Exception */ protected function sendImageToMediaServer($fullFilePath, $mimeType) { $config = Zend_Registry::get('config'); $url = $config->images->media->upload; $client = new Zend_Http_Client($url); $client->setFileUpload($fullFilePath, basename($fullFilePath), null, $mimeType); $response = $client->request('POST'); if ($response->getStatus() > 200) { - $this->_errorMsg = $response->getBody(); - - return null; + throw new Default_Model_Exception_Image('Could not upload file to ' . $url . ' - server response: ' . $response->getBody()); } return $response->getBody(); } public function save($image) { foreach ($image as $key => $value) { if (!in_array($key, array_keys($this->_fields))) { unset($image[$key]); } } if (isset($image['filename']) && !isset($image['code'])) { $image['code'] = $this->_trimExtension($image['filename']); } if (isset($image['id'])) { return $this->_update($image); } else { return $this->_add($image); } } private function _update($image) { if (!isset($image['id'])) { throw new Exception('Invalid update without an id'); } else { $id = (int)$image['id']; } return $this->update($image, array('id = ?' => $id)); } private function _add($image) { return $this->insert($image); } /** * @param Zend_Form_Element_File $formFileElement * * @return string * @throws Zend_Exception * @todo wrong place for this method */ public function saveImage($formFileElement) { if (empty($formFileElement)) { Zend_Registry::get('logger')->err(__METHOD__ . ' - form file element empty'); return null; } $filesInfo = $formFileElement->getFileInfo(); if (1 < count($filesInfo)) { throw new Zend_Exception('Element contains more than one file elements'); } foreach ($filesInfo as $file => $fileInfo) { if (null == $fileInfo['size']) { return null; } $contentType = mime_content_type($fileInfo['tmp_name']); if (false === in_array($contentType, array_keys($this->_allowed))) { throw new Zend_Exception('Format not allowed: ' . $contentType . ' for img: ' . $fileInfo['name']); } $generatedFilename = $this->_generateFilename($fileInfo['tmp_name']); $destinationFile = IMAGES_UPLOAD_PATH . $generatedFilename . $this->_allowed[$contentType]; Zend_Registry::get('logger')->info(__METHOD__ . ' - destination file path: ' . $destinationFile); if (copy($fileInfo['tmp_name'], $destinationFile)) { if (file_exists($fileInfo['tmp_name'])) { if (false === unlink($fileInfo['tmp_name'])) { Zend_Registry::get('logger')->warn(__METHOD__ . ' - can not delete temp file: ' . $fileInfo['tmp_name']) ; } } Zend_Registry::get('logger')->debug(__METHOD__ . ' - Start upload picture - ' . print_r($destinationFile, true)) ; $srcPathOnMediaServer = $this->sendImageToMediaServer($destinationFile, $contentType); if (file_exists($destinationFile)) { if (false === unlink($destinationFile)) { Zend_Registry::get('logger')->warn(__METHOD__ . ' - can not delete file: ' . $destinationFile); } } if (!$srcPathOnMediaServer) { throw new Zend_Exception("Error in upload to CDN-Server. \n Server message:\n" . $this->_errorMsg); } Zend_Registry::get('logger')->debug(__METHOD__ . ' - End upload a picture - ' . print_r(IMAGES_UPLOAD_PATH . $srcPathOnMediaServer, true)) ; return $srcPathOnMediaServer; } } } /** * @param Zend_Form_Element_File $formFileElement * * @return array * @throws Zend_Exception */ public function saveImages($formFileElement) { if (empty($formFileElement)) { return array(); } $resultPath = array(); $filesInfo = $formFileElement->getFileInfo(); foreach ($filesInfo as $file => $fileInfo) { if (null == $fileInfo['size']) { continue; } $contentType = mime_content_type($fileInfo['tmp_name']); if (!in_array($contentType, array_keys($this->_allowed))) { throw new Zend_Exception('Format not allowed: ' . $contentType . ' for img: ' . $fileInfo['name']); } $generatedFilename = $this->_generateFilename($fileInfo['tmp_name']); $destinationFile = IMAGES_UPLOAD_PATH . $generatedFilename . $this->_allowed[$contentType]; if (copy($fileInfo['tmp_name'], $destinationFile)) { Zend_Registry::get('logger')->debug(__METHOD__ . ' - Start upload picture - ' . print_r($destinationFile, true)) ; $srcPathOnMediaServer = $this->sendImageToMediaServer($destinationFile, $contentType); if (!$srcPathOnMediaServer) { throw new Zend_Exception("Error in upload to CDN-Server. \n Server message:\n" . $this->_errorMsg); } Zend_Registry::get('logger')->debug(__METHOD__ . ' - End upload a picture - ' . print_r(IMAGES_UPLOAD_PATH . $srcPathOnMediaServer, true)) ; $resultPath[] = $srcPathOnMediaServer; } } return $resultPath; } public function getAllowedFileExtension() { return $this->_allowedFileExtension; } public function getAllowedMimeTypes() { return array_keys($this->getAllowed()); } public function getAllowed() { return $this->_allowed; } public function setAllowed($allowed) { $this->_allowed = $allowed; } public function getMaxsize() { return $this->_maxsize; } public function setMaxsize($maxsize) { $this->_maxsize = $maxsize; } } \ No newline at end of file diff --git a/application/modules/default/models/Exception/Image.php b/application/modules/default/models/Exception/Image.php new file mode 100644 index 000000000..3e9d691b0 --- /dev/null +++ b/application/modules/default/models/Exception/Image.php @@ -0,0 +1,27 @@ +. + **/ + +class Default_Model_Exception_Image extends Zend_Exception +{ + +} \ No newline at end of file diff --git a/application/modules/default/models/Member.php b/application/modules/default/models/Member.php index a6e8e4433..2b020622b 100644 --- a/application/modules/default/models/Member.php +++ b/application/modules/default/models/Member.php @@ -1,1331 +1,1341 @@ . - - **/ -use YoHang88\LetterAvatar\LetterAvatar; + +use YoHang88\LetterAvatar\LetterAvatar; + class Default_Model_Member extends Default_Model_DbTable_Member { const CASE_INSENSITIVE = 1; /** * @param int $count * @param string $orderBy * @param string $dir * * @return Zend_Db_Table_Rowset * @throws Zend_Exception */ public function fetchNewActiveMembers($count = 100, $orderBy = 'created_at', $dir = 'DESC') { if (empty($count)) { return $this->generateRowSet($this->createRow()); } $allowedDirection = array('desc' => true, 'asc' => true); if (false == isset($allowedDirection[strtolower($dir)])) { $dir = null; } /** @var Zend_Cache_Core $cache */ $cache = Zend_Registry::get('cache'); $cacheName = __FUNCTION__ . md5($count . $orderBy . $dir); $members = $cache->load($cacheName); if ($members) { return $members; } else { $sql = ' SELECT count(*) AS `total_count` FROM `member` WHERE `is_active` = :activeVal AND `type` = :typeVal AND `profile_image_url` <> :defaultImgUrl AND `profile_image_url` LIKE :likeImgUrl '; $resultCnt = $this->_db->fetchRow($sql, array( 'activeVal' => Default_Model_Member::MEMBER_ACTIVE, 'typeVal' => Default_Model_Member::MEMBER_TYPE_PERSON, 'defaultImgUrl' => 'hive/user-pics/nopic.png', 'likeImgUrl' => 'hive/user-bigpics/0/%' )); $totalcnt = $resultCnt['total_count']; if ($totalcnt > $count) { $offset = ' offset ' . rand(0, $totalcnt - $count); } else { $offset = ''; } $sql = ' SELECT * FROM `member` WHERE `is_active` = :activeVal AND `type` = :typeVal AND `profile_image_url` <> :defaultImgUrl AND `profile_image_url` LIKE :likeImgUrl '; //$sql .= ' ORDER BY ' . $this->_db->quoteIdentifier($orderBy) . ' ' . $dir; $sql .= ' LIMIT ' . $this->_db->quote($count, Zend_Db::INT_TYPE); $sql .= $offset; $resultMembers = $this->getAdapter()->query($sql, array( 'activeVal' => Default_Model_Member::MEMBER_ACTIVE, 'typeVal' => Default_Model_Member::MEMBER_TYPE_PERSON, 'defaultImgUrl' => 'hive/user-pics/nopic.png', 'likeImgUrl' => 'hive/user-bigpics/0/%' - ))->fetchAll() - ; + ))->fetchAll(); $resultSet = $this->generateRowSet($resultMembers); $cache->save($resultSet, $cacheName, array(), 14400); return $resultSet; } } /** * @param $data * * @return Zend_Db_Table_Rowset */ protected function generateRowSet($data) { $classRowSet = $this->getRowsetClass(); $returnRowSet = new $classRowSet(array( 'table' => $this, 'rowClass' => $this->getRowClass(), 'stored' => true, 'data' => $data )); return $returnRowSet; } /** * @return array * @deprecated */ public function getMembersForSelectList() { $selectArr = $this->_db->fetchAll("SELECT `member_id`,`username`,`firstname`, `lastname` FROM {$this->_name} WHERE is_active=1 AND is_deleted=0 ORDER BY username"); $arrayModified = array(); $arrayModified[0] = "Benutzer wählen"; foreach ($selectArr as $item) { $tmpStr = ($item['firstname']) ? $item['firstname'] : ""; $tmpStr .= ($item['lastname']) ? ", " . $item['lastname'] : ""; $tmpStr = ($tmpStr != "") ? " (" . $tmpStr . ")" : ""; $arrayModified[$item['member_id']] = stripslashes($item['username'] . $tmpStr); } return $arrayModified; } /** * @param int $member_id * * @param $verification_value * * @return boolean returns true if successful * @throws Zend_Db_Statement_Exception */ public function activateMemberFromVerification($member_id, $verification_value) { $sql = " UPDATE `member` STRAIGHT_JOIN `member_email` ON `member`.`member_id` = `member_email`.`email_member_id` AND `member_email`.`email_checked` IS NULL AND `member`.`is_deleted` = 0 AND `member_email`.`email_deleted` = 0 SET `member`.`mail_checked` = 1, `member`.`is_active` = 1, `member`.`changed_at` = NOW(), `member_email`.`email_checked` = NOW() WHERE `member`.`member_id` = :memberId AND `member_email`.`email_verification_value` = :verificationValue; "; $stmnt = $this->_db->query($sql, array('memberId' => $member_id, 'verificationValue' => $verification_value)); return $stmnt->rowCount() > 0 ? true : false; } /** * @param int $member_id * * @throws Zend_Exception */ public function setDeleted($member_id) { $updateValues = array( 'is_active' => 0, 'is_deleted' => 1, 'deleted_at' => new Zend_Db_Expr('Now()'), ); $this->update($updateValues, $this->_db->quoteInto('member_id=?', $member_id, 'INTEGER')); - + $memberLog = new Default_Model_MemberDeactivationLog(); $memberLog->logMemberAsDeleted($member_id); - + $this->setMemberProjectsDeleted($member_id); $this->setMemberCommentsDeleted($member_id); $this->setMemberRatingsDeleted($member_id); $this->setMemberReportingsDeleted($member_id); $this->setMemberEmailsDeleted($member_id); //$this->setMemberPlingsDeleted($member_id); //$this->removeMemberProjectsFromSearch($member_id); $this->setDeletedInMaterializedView($member_id); $this->setDeletedInSubSystems($member_id); } //User ist mind. 1 jahr alt, user ist supporter, user hat minimum 20 kommentare - public function validDeleteMemberFromSpam($member_id) - { - $sql ='select - m.created_at - , (m.created_at+ INTERVAL 12 MONTH < NOW()) is_old - ,(select count(1) from comments c where c.comment_member_id = m.member_id and comment_active = 1) comments - ,(select (DATE_ADD(max(active_time), INTERVAL 1 YEAR) > now()) from support s where s.status_id = 2 AND s.member_id =m.member_id) is_supporter - from member m where member_id = :member_id'; - $result = $this->_db->fetchRow($sql, array( - 'member_id' => $member_id, - )); - if($result['is_supporter'] && $result['is_supporter'] ==1) - { - return false; - } - if($result['is_old'] ==1 || $result['comments']>20) - { - return false; - } - return true; - } private function setMemberProjectsDeleted($member_id) { $modelProject = new Default_Model_Project(); $modelProject->setAllProjectsForMemberDeleted($member_id); } private function setMemberCommentsDeleted($member_id) { $modelComments = new Default_Model_ProjectComments(); $modelComments->setAllCommentsForUserDeleted($member_id); } private function setMemberRatingsDeleted($member_id) { $modelRatings = new Default_Model_DbTable_ProjectRating(); $affectedRows = $modelRatings->setDeletedByMemberId($member_id); if (false === empty($affectedRows)) { $modelProject = new Default_Model_DbTable_Project(); $modelProject->deleteLikes($affectedRows); } } private function setMemberReportingsDeleted($member_id) { $modelReportsProject = new Default_Model_DbTable_ReportProducts(); $modelReportsProject->setDeleteByMember($member_id); $modelReportsComments = new Default_Model_DbTable_ReportComments(); $modelReportsComments->setDeleteByMember($member_id); } private function setMemberEmailsDeleted($member_id) { $modelEmail = new Default_Model_DbTable_MemberEmail(); $modelEmail->setDeletedByMember($member_id); } - - private function setMemberEmailsActivated($member_id) - { - $modelEmail = new Default_Model_DbTable_MemberEmail(); - $modelEmail->setActivatedByMember($member_id); - } private function setDeletedInMaterializedView($member_id) { $sql = "UPDATE `stat_projects` SET `status` = :new_status WHERE `member_id` = :member_id"; - $this->_db->query($sql, array('new_status' => Default_Model_DbTable_Project::PROJECT_DELETED, 'member_id' => $member_id)) - ->execute() - ; + $this->_db->query($sql, + array('new_status' => Default_Model_DbTable_Project::PROJECT_DELETED, 'member_id' => $member_id)) + ->execute(); + } + + private function setDeletedInSubSystems($member_id) + { + try { + $id_server = new Default_Model_Ocs_OAuth(); + $id_server->deleteUser($member_id); + Zend_Registry::get('logger')->debug(__METHOD__ . ' - oauth : ' . implode(PHP_EOL . " - ", + $id_server->getMessages())); + } catch (Exception $e) { + Zend_Registry::get('logger')->err($e->getMessage() . PHP_EOL . $e->getTraceAsString()); + } + try { + $ldap_server = new Default_Model_Ocs_Ldap(); + $ldap_server->deleteUser($member_id); + Zend_Registry::get('logger')->debug(__METHOD__ . ' - ldap : ' . implode(PHP_EOL . " - ", + $ldap_server->getMessages())); + } catch (Exception $e) { + Zend_Registry::get('logger')->err($e->getMessage() . PHP_EOL . $e->getTraceAsString()); + } + try { + $openCode = new Default_Model_Ocs_Gitlab(); + $openCode->blockUser($member_id); + $openCode->blockUserProjects($member_id); + Zend_Registry::get('logger')->debug(__METHOD__ . ' - opencode : ' . implode(PHP_EOL . " - ", + $openCode->getMessages())); + } catch (Exception $e) { + Zend_Registry::get('logger')->err($e->getMessage() . PHP_EOL . $e->getTraceAsString()); + } + try { + $forum = new Default_Model_Ocs_Forum(); + $forum->blockUser($member_id); + $forum->blockUserPosts($member_id); + Zend_Registry::get('logger')->debug(__METHOD__ . ' - forum : ' . implode(PHP_EOL . " - ", + $forum->getMessages())); + } catch (Exception $e) { + Zend_Registry::get('logger')->err($e->getMessage() . PHP_EOL . $e->getTraceAsString()); + } + } + + public function validDeleteMemberFromSpam($member_id) + { + $sql = 'SELECT + `m`.`created_at` + , (`m`.`created_at`+ INTERVAL 12 MONTH < NOW()) `is_old` + ,(SELECT count(1) FROM `comments` `c` WHERE `c`.`comment_member_id` = `m`.`member_id` AND `comment_active` = 1) `comments` + ,(SELECT (DATE_ADD(max(`active_time`), INTERVAL 1 YEAR) > now()) FROM `support` `s` WHERE `s`.`status_id` = 2 AND `s`.`member_id` =`m`.`member_id`) `is_supporter` + FROM `member` `m` WHERE `member_id` = :member_id'; + $result = $this->_db->fetchRow($sql, array( + 'member_id' => $member_id, + )); + if ($result['is_supporter'] && $result['is_supporter'] == 1) { + return false; + } + if ($result['is_old'] == 1 || $result['comments'] > 20) { + return false; + } + + return true; } /** * @param int $member_id * * @throws Zend_Db_Exception */ public function setActivated($member_id) { $updateValues = array( 'is_active' => 1, 'is_deleted' => 0, 'changed_at' => new Zend_Db_Expr('Now()'), 'deleted_at' => null ); $this->update($updateValues, $this->_db->quoteInto('member_id=?', $member_id, 'INTEGER')); - + $memberLog = new Default_Model_MemberDeactivationLog(); $memberLog->removeLogMemberAsDeleted($member_id); - + $this->setMemberProjectsActivated($member_id); $this->setMemberCommentsActivated($member_id); $this->setMemberEmailsActivated($member_id); $this->setActivatedInSubsystems($member_id); - + //$this->setMemberPlingsActivated($member_id); } private function setMemberProjectsActivated($member_id) { $modelProject = new Default_Model_Project(); $modelProject->setAllProjectsForMemberActivated($member_id); } private function setMemberCommentsActivated($member_id) { $modelComment = new Default_Model_ProjectComments(); $modelComment->setAllCommentsForUserActivated($member_id); } + private function setMemberEmailsActivated($member_id) + { + $modelEmail = new Default_Model_DbTable_MemberEmail(); + $modelEmail->setActivatedByMember($member_id); + } + + private function setActivatedInSubsystems($member_id) + { + try { + $id_server = new Default_Model_Ocs_OAuth(); + $id_server->updateUser($member_id); + Zend_Registry::get('logger')->debug(__METHOD__ . ' - oauth : ' . print_r($id_server->getMessages(), true)); + } catch (Exception $e) { + Zend_Registry::get('logger')->err($e->getMessage() . PHP_EOL . $e->getTraceAsString()); + } + try { + $ldap_server = new Default_Model_Ocs_Ldap(); + $ldap_server->createUser($member_id); + Zend_Registry::get('logger')->debug(__METHOD__ . ' - ldap : ' . implode(PHP_EOL . " - ", + $ldap_server->getMessages())); + } catch (Exception $e) { + Zend_Registry::get('logger')->err($e->getMessage() . PHP_EOL . $e->getTraceAsString()); + } + try { + $openCode = new Default_Model_Ocs_Gitlab(); + $openCode->unblockUser($member_id); + $openCode->unblockUserProjects($member_id); + Zend_Registry::get('logger')->debug(__METHOD__ . ' - opencode : ' . implode(PHP_EOL . " - ", + $openCode->getMessages())); + } catch (Exception $e) { + Zend_Registry::get('logger')->err($e->getMessage() . PHP_EOL . $e->getTraceAsString()); + } + try { + $forum = new Default_Model_Ocs_Forum(); + $forum->unblockUser($member_id); + $forum->unblockUserPosts($member_id); + Zend_Registry::get('logger')->debug(__METHOD__ . ' - forum : ' . implode(PHP_EOL." - ", $forum->getMessages())); + } catch (Exception $e) { + Zend_Registry::get('logger')->err($e->getMessage() . PHP_EOL . $e->getTraceAsString()); + } + } + /** * @param int $member_id * * @param bool $onlyNotDeleted * * @return Zend_Db_Table_Row * @throws Zend_Db_Statement_Exception */ public function fetchMemberData($member_id, $onlyNotDeleted = true) { if (null === $member_id) { return null; } $sql = ' - SELECT m.*, `member_email`.`email_address` AS `mail`, IF(ISNULL(`member_email`.`email_checked`),0,1) AS `mail_checked`, `member_email`.`email_address`, `mei`.`external_id`, `mei`.`gitlab_user_id` + SELECT `m`.*, `member_email`.`email_address` AS `mail`, IF(ISNULL(`member_email`.`email_checked`),0,1) AS `mail_checked`, `member_email`.`email_address`, `mei`.`external_id`, `mei`.`gitlab_user_id` FROM `member` AS `m` JOIN `member_email` ON `m`.`member_id` = `member_email`.`email_member_id` AND `member_email`.`email_primary` = 1 LEFT JOIN `member_external_id` AS `mei` ON `mei`.`member_id` = `m`.`member_id` WHERE - (m.member_id = :memberId) + (`m`.`member_id` = :memberId) '; if ($onlyNotDeleted) { $sql .= " AND (m.is_deleted = " . self::MEMBER_NOT_DELETED . ")"; } $result = $this->getAdapter()->query($sql, array('memberId' => $member_id))->fetch(); $classRow = $this->getRowClass(); return new $classRow(array('table' => $this, 'stored' => true, 'data' => $result)); } /** * @param $member_id * @param bool $onlyActive * * @return null|Zend_Db_Table_Row_Abstract * @throws Zend_Db_Statement_Exception */ public function fetchMember($member_id, $onlyActive = true) { if (empty($member_id)) { return null; } $sql = " SELECT `m`.*, `member_email`.`email_address` AS `mail`, IF(ISNULL(`member_email`.`email_checked`),0,1) AS `mail_checked`, `member_email`.`email_address`, `mei`.`external_id` FROM `member` AS `m` JOIN `member_email` ON `m`.`member_id` = `member_email`.`email_member_id` AND `member_email`.`email_primary` = 1 LEFT JOIN `member_external_id` AS `mei` ON `mei`.`member_id` = `m`.`member_id` WHERE `m`.`member_id` = :memberId"; if ($onlyActive) { $sql .= " AND `m`.`is_deleted` = " . self::MEMBER_NOT_DELETED . " AND `m`.`is_active` = " . self::MEMBER_ACTIVE; } $stmnt = $this->_db->query($sql, array('memberId' => $member_id)); if ($stmnt->rowCount() == 0) { return null; } return $this->generateRowClass($stmnt->fetch()); } /** * @param string $user_name * * @return Zend_Db_Table_Row */ public function fetchMemberFromHiveUserName($user_name) { $sql = " SELECT * FROM `member` WHERE `source_id` = :sourceId AND `username` = :userName "; - return $this->_db->fetchRow($sql, array('sourceId' => Default_Model_Member::SOURCE_HIVE, 'userName' => $user_name)); + return $this->_db->fetchRow($sql, + array('sourceId' => Default_Model_Member::SOURCE_HIVE, 'userName' => $user_name)); } - + /** * @param string $user_name * * @return Zend_Db_Table_Row */ public function fetchMemberFromHiveUserId($user_id) { $sql = " SELECT * FROM `member` WHERE `source_id` = :sourceId AND `source_pk` = :userId "; return $this->_db->fetchRow($sql, array('sourceId' => Default_Model_Member::SOURCE_HIVE, 'userId' => $user_id)); } /** * @param int $member_id * @param int $limit * * @return Zend_Db_Table_Rowset */ public function fetchFollowedMembers($member_id, $limit = null) { $sql = " SELECT member_follower.member_id, member_follower.follower_id, member.* FROM member_follower LEFT JOIN member ON member_follower.member_id = member.member_id WHERE member_follower.follower_id = :followerId AND member.is_active = :activeVal GROUP BY member_follower.member_id ORDER BY max(member_follower.member_follower_id) DESC "; if (null != $limit) { $sql .= $this->_db->quoteInto(" limit ?", $limit, 'INTEGER'); } $result = $this->_db->fetchAll($sql, array('followerId' => $member_id, 'activeVal' => self::MEMBER_ACTIVE)); return $this->generateRowSet($result); } - /** * @param int $member_id * @param null $limit * * @return Zend_Db_Table_Rowset_Abstract */ public function fetchFollowedProjects($member_id, $limit = null) { $sql = " SELECT `project_follower`.`project_id`, `project`.`title`, `project`.`image_small` FROM `project_follower` JOIN `project` ON `project_follower`.`project_id` = `project`.`project_id` WHERE `project_follower`.`member_id` = :member_id AND `project`.`status` = :project_status AND `project`.`type_id` = 1 ORDER BY `project_follower`.`project_follower_id` DESC "; if (null != $limit) { $sql .= $this->_db->quoteInto(" limit ?", $limit, 'INTEGER'); } $result = - $this->_db->fetchAll($sql, array('member_id' => $member_id, 'project_status' => Default_Model_Project::PROJECT_ACTIVE)); + $this->_db->fetchAll($sql, + array('member_id' => $member_id, 'project_status' => Default_Model_Project::PROJECT_ACTIVE)); return $this->generateRowSet($result); } public function fetchPlingedProjects($member_id, $limit = null) { $sql = " SELECT project_category.title AS catTitle, project.*, member.*, plings.* FROM plings LEFT JOIN project ON plings.project_id = project.project_id LEFT JOIN project_category ON project.project_category_id = project_category.project_category_id LEFT JOIN member ON project.member_id = member.member_id WHERE plings.member_id = :member_id AND plings.status_id = 2 AND project.status = :project_status AND project.type_id = 1 ORDER BY plings.create_time DESC "; if (null != $limit) { $sql .= $this->_db->quoteInto(" limit ?", $limit, 'INTEGER'); } $result = - $this->_db->fetchAll($sql, array('member_id' => $member_id, 'project_status' => Default_Model_Project::PROJECT_ACTIVE)); + $this->_db->fetchAll($sql, + array('member_id' => $member_id, 'project_status' => Default_Model_Project::PROJECT_ACTIVE)); return $this->generateRowSet($result); } public function fetchProjectsSupported($member_id, $limit = null) { $sql = " SELECT `project_category`.`title` AS `catTitle`, `project`.`project_id`, `project`.`title`, `project`.`image_small`, `plings`.`member_id`, `plings`.`amount`, `plings`.`create_time`, `member`.`profile_image_url`, `member`.`username` FROM `plings` JOIN `project` ON `plings`.`project_id` = `project`.`project_id` JOIN `project_category` ON `project`.`project_category_id` = `project_category`.`project_category_id` JOIN `member` ON `plings`.`member_id` = `member`.`member_id` WHERE `project`.`member_id` = :member_id AND `plings`.`status_id` = 2 AND `project`.`status` = :project_status AND `project`.`type_id` = 1 ORDER BY `plings`.`create_time` DESC "; if (null != $limit) { $sql .= $this->_db->quoteInto(" limit ?", $limit, 'INTEGER'); } $result = - $this->_db->fetchAll($sql, array('member_id' => $member_id, 'project_status' => Default_Model_Project::PROJECT_ACTIVE)); + $this->_db->fetchAll($sql, + array('member_id' => $member_id, 'project_status' => Default_Model_Project::PROJECT_ACTIVE)); return $this->generateRowSet($result); } /** * @param $userData * * @return array * @throws Exception */ public function createNewUser($userData) { $uuidMember = Local_Tools_UUID::generateUUID(); if (false == isset($userData['password'])) { throw new Exception(__METHOD__ . ' - user password is not set.'); } $userData['password'] = - Local_Auth_Adapter_Ocs::getEncryptedPassword($userData['password'], Default_Model_DbTable_Member::SOURCE_LOCAL); + Local_Auth_Adapter_Ocs::getEncryptedPassword($userData['password'], + Default_Model_DbTable_Member::SOURCE_LOCAL); if (false == isset($userData['roleId'])) { $userData['roleId'] = self::ROLE_ID_DEFAULT; } if ((false == isset($userData['avatar'])) OR (false == isset($userData['profile_image_url']))) { $imageFilename = $this->generateIdentIcon($userData, $uuidMember); $userData['avatar'] = $imageFilename; $userData['profile_image_url'] = IMAGES_MEDIA_SERVER . '/cache/200x200-2/img/' . $imageFilename; } if (false == isset($userData['uuid'])) { $userData['uuid'] = $uuidMember; } if (false == isset($userData['mail_checked'])) { $userData['mail_checked'] = 0; } - + //email is allways lower case - $userData['mail'] = strtolower( trim( $userData['mail'] ) ); + $userData['mail'] = strtolower(trim($userData['mail'])); $newUser = $this->storeNewUser($userData)->toArray(); $memberMail = $this->createPrimaryMailAddress($newUser); $externalId = $this->createExternalId($newUser['member_id']); $newUser['verificationVal'] = $memberMail->email_verification_value; $newUser['externalId'] = $externalId; return $newUser; } - /** - * @param $userData - * @param $uuidMember - * - * @return string - * @throws Exception - */ - protected function generateIdentIcon_old($userData, $uuidMember) - { - $identIcon = new Local_Tools_Identicon(); - $tmpImagePath = IMAGES_UPLOAD_PATH . 'tmp/' . $uuidMember . '.png'; - imagepng($identIcon->renderIdentIcon(sha1($userData['mail']), 1100), $tmpImagePath); - - $imageService = new Default_Model_DbTable_Image(); - $imageFilename = $imageService->saveImageOnMediaServer($tmpImagePath); - - return $imageFilename; - } - /** * @param $userData * @param $uuidMember * * @return string * @throws Exception */ protected function generateIdentIcon($userData, $uuidMember) { require_once 'vendor/autoload.php'; - // $name = substr($userData['username'],0,1).' '.substr($userData['username'],1); - $name = $userData['username'].' '; - $avatar = new LetterAvatar($name,'square', 400); + // $name = substr($userData['username'],0,1).' '.substr($userData['username'],1); + $name = $userData['username'] . ' '; + $avatar = new LetterAvatar($name, 'square', 400); $tmpImagePath = IMAGES_UPLOAD_PATH . 'tmp/' . $uuidMember . '.png'; - $avatar->saveAs($tmpImagePath, LetterAvatar::MIME_TYPE_PNG); + $avatar->saveAs($tmpImagePath, LetterAvatar::MIME_TYPE_PNG); $imageService = new Default_Model_DbTable_Image(); $imageFilename = $imageService->saveImageOnMediaServer($tmpImagePath); + return $imageFilename; } /** * @param array $userData * * @return Zend_Db_Table_Row_Abstract */ public function storeNewUser($userData) { $newUserData = $this->createRow($userData); $newUserData->save(); //create a user specified main project in project table $projectId = $this->createPersonalProject($newUserData->toArray()); //and save the id in member table $newUserData->main_project_id = $projectId; $newUserData->save(); return $newUserData; } /** * @param array $userData * * @return mixed $projectId */ protected function createPersonalProject($userData) { $tableProject = new Default_Model_Project(); /** @var Default_Model_DbRow_Project $newPersonalProject */ $newPersonalProject = $tableProject->createRow($userData); $newPersonalProject->uuid = Local_Tools_UUID::generateUUID(); $newPersonalProject->project_category_id = $newPersonalProject::CATEGORY_DEFAULT_PROJECT; $newPersonalProject->status = $newPersonalProject::STATUS_PROJECT_ACTIVE; $newPersonalProject->image_big = $newPersonalProject::DEFAULT_AVATAR_IMAGE; $newPersonalProject->image_small = $newPersonalProject::DEFAULT_AVATAR_IMAGE; $newPersonalProject->creator_id = $userData['member_id']; $newPersonalProject->title = $newPersonalProject::PERSONAL_PROJECT_TITLE; $projectId = $newPersonalProject->save(); return $projectId; } /** * @param array $newUser * @param bool $isVerified * * @return Zend_Db_Table_Row_Abstract * @throws Exception */ private function createPrimaryMailAddress($newUser) { $modelEmail = new Default_Model_MemberEmail(); $userMail = $modelEmail->saveEmailAsPrimary($newUser['member_id'], $newUser['mail'], $newUser['mail_checked']); return $userMail; } /** * @param int $member_id * * @return string */ private function createExternalId($member_id) { $modelExternalId = new Default_Model_DbTable_MemberExternalId(); $externalId = $modelExternalId->createExternalId($member_id); return $externalId; } public function fetchTotalMembersCount() { $sql = " SELECT count(1) AS `total_member_count` FROM `member` "; $result = $this->_db->fetchRow($sql); return $result['total_member_count']; } public function fetchTotalMembersInStoreCount() { $sql = " SELECT count(1) AS `total_member_count` FROM `member` "; $result = $this->_db->fetchRow($sql); return $result['total_member_count']; } /** * @param string $email * * @return null|Zend_Db_Table_Row_Abstract * @deprecated */ public function fetchCheckedActiveLocalMemberByEmail($email) { - $sel = $this->select()->where('mail=?', $email)->where('is_deleted = ?', Default_Model_DbTable_Member::MEMBER_NOT_DELETED) + $sel = $this->select()->where('mail=?', $email)->where('is_deleted = ?', + Default_Model_DbTable_Member::MEMBER_NOT_DELETED) ->where('is_active = ?', Default_Model_DbTable_Member::MEMBER_ACTIVE) ->where('mail_checked = ?', Default_Model_DbTable_Member::MEMBER_MAIL_CHECKED) - ->where('login_method = ?', Default_Model_DbTable_Member::MEMBER_LOGIN_LOCAL) - ; + ->where('login_method = ?', Default_Model_DbTable_Member::MEMBER_LOGIN_LOCAL); return $this->fetchRow($sel); } public function fetchEarnings($member_id, $limit = null) { $sql = " SELECT `project_category`.`title` AS `catTitle`, `project`.*, `member`.*, `plings`.* FROM `plings` JOIN `project` ON `plings`.`project_id` = `project`.`project_id` JOIN `project_category` ON `project`.`project_category_id` = `project_category`.`project_category_id` JOIN `member` ON `project`.`member_id` = `member`.`member_id` WHERE `plings`.`status_id` = 2 AND `project`.`status` = :status AND `project`.`type_id` = 1 AND `project`.`member_id` = :memberId ORDER BY `plings`.`create_time` DESC "; if (null != $limit) { $sql .= $this->_db->quoteInto(" limit ?", $limit, 'INTEGER'); } - $result = $this->_db->fetchAll($sql, array('memberId' => $member_id, 'status' => Default_Model_Project::PROJECT_ACTIVE)); + $result = $this->_db->fetchAll($sql, + array('memberId' => $member_id, 'status' => Default_Model_Project::PROJECT_ACTIVE)); return $this->generateRowSet($result); } /** * Finds an active user by given username or email ($identity) * Returns an empty rowset when no user found. * * @param string $identity could be the username or users mail address * @param bool $withLoginLocal * * @return Zend_Db_Table_Row_Abstract */ public function findActiveMemberByIdentity($identity, $withLoginLocal = false) { $sqlName = "SELECT * FROM `member` WHERE `is_active` = :active AND `is_deleted` = :deleted AND `username` = :identity"; $sqlMail = "SELECT * FROM `member` WHERE `is_active` = :active AND `is_deleted` = :deleted AND `mail` = :identity"; if ($withLoginLocal) { $sqlName .= " AND login_method = '" . self::MEMBER_LOGIN_LOCAL . "'"; $sqlMail .= " AND login_method = '" . self::MEMBER_LOGIN_LOCAL . "'"; } // test identity as username $resultName = $this->getAdapter()->fetchRow($sqlName, - array('active' => self::MEMBER_ACTIVE, 'deleted' => self::MEMBER_NOT_DELETED, 'identity' => $identity)) - ; + array('active' => self::MEMBER_ACTIVE, 'deleted' => self::MEMBER_NOT_DELETED, 'identity' => $identity)); if ((false !== $resultName) AND (count($resultName) > 0)) { return $this->generateRowClass($resultName); } // test identity as mail $resultMail = $this->getAdapter()->fetchRow($sqlMail, - array('active' => self::MEMBER_ACTIVE, 'deleted' => self::MEMBER_NOT_DELETED, 'identity' => $identity)) - ; + array('active' => self::MEMBER_ACTIVE, 'deleted' => self::MEMBER_NOT_DELETED, 'identity' => $identity)); if ((false !== $resultMail) AND (count($resultMail) > 0)) { return $this->generateRowClass($resultMail); } return $this->createRow(); } - + /** * @param string $value * * @return mixed */ - public function findActiveMemberByName($username){ - $sql = ' + public function findActiveMemberByName($username) + { + $sql = ' select m.member_id,m.username,profile_image_url from member m where m.is_active=1 and m.is_deleted = 0 - and m.username like "'.$username.'%" + and m.username like "' . $username . '%" limit 20 '; - $result = $this->getAdapter()->fetchAll($sql); - return $result; - } + $result = $this->getAdapter()->fetchAll($sql); + return $result; + } /** * @param string $value * * @return mixed */ public function findMemberForMailHash($value) { $sql = " SELECT `m`.* FROM `member_email` `me` JOIN `member` `m` ON `m`.`member_id` = `me`.`email_member_id` WHERE `m`.`is_active` = 1 AND `m`.`is_deleted` = 0 AND `me`.`email_hash` = :email_hash "; $result = $this->getAdapter()->fetchAll($sql, array('email_hash' => $value)); if ($result && count($result) > 0) { $member = $result[0]; return $member; } } - /** * @param Zend_Db_Table_Row_Abstract $memberData * * @return bool */ public function isHiveUser($memberData) { if (empty($memberData)) { return false; } - //20180801 ronald: If a hive user change his password, he gets the ocs password type and we do + //20180801 ronald: If a hive user change his password, he gets the ocs password type and we do //have to check against the old hive password style //if ($memberData->source_id == self::SOURCE_HIVE) { // return true; //} if ($memberData->password_type == self::PASSWORD_TYPE_HIVE) { return true; } return false; } public function fetchActiveHiveUserByUsername($username) { $sql = 'SELECT * FROM member WHERE username = :username AND is_active = 1 AND member.source_id = 1 AND member.is_deleted = 0'; $result = $this->getAdapter()->query($sql, array('username' => $username))->fetch(); return $result; } - + public function fetchActiveUserByUsername($username) { - $sql = 'SELECT DISTINCT member.member_id - FROM member - WHERE LOWER(username) = :username - AND is_active = 1 - AND member.is_deleted = 0'; + $sql = 'SELECT DISTINCT `member`.`member_id` + FROM `member` + WHERE LOWER(`username`) = :username + AND `is_active` = 1 + AND `member`.`is_deleted` = 0'; $result = $this->getAdapter()->query($sql, array('username' => strtolower($username)))->fetchAll(); - - if($result && count($result)>0) { + + if ($result && count($result) > 0) { $member_id = $result[0]['member_id']; + return $member_id; } return null; } public function fetchCommentsCount($member_id) { $sql = " SELECT count(1) AS count FROM comments where comment_target_id <> 0 and comment_member_id = :member_id and comment_active = :comment_status "; $result = $this->_db->fetchRow($sql, array( 'member_id' => $member_id, 'comment_status' => Default_Model_DbTable_Comments::COMMENT_ACTIVE )); return $result['count']; } /** * @param $member_id * @param null $limit * * @return Zend_Paginator * @throws Zend_Paginator_Exception */ public function fetchComments($member_id, $limit = null) { $result = $this->fetchCommentsList($member_id, $limit); if (count($result) > 0) { return new Zend_Paginator(new Zend_Paginator_Adapter_Array($result)); } else { return new Zend_Paginator(new Zend_Paginator_Adapter_Array(array())); } } /** * @param $member_id * @param null $limit * * @return Zend_Paginator * @throws Zend_Paginator_Exception */ public function fetchCommentsList($member_id, $limit = null) { $sql = ' SELECT - comment_id - ,comment_text - ,member.member_id - ,member.profile_image_url - ,comment_created_at - ,stat_projects.username - ,stat_projects.project_member_id - ,comment_target_id - ,stat_projects.title - ,stat_projects.project_id - ,stat_projects.laplace_score - ,stat_projects.count_likes - ,stat_projects.count_dislikes - ,stat_projects.image_small - ,stat_projects.version - ,stat_projects.cat_title - ,stat_projects.count_comments - ,stat_projects.changed_at - ,stat_projects.created_at - FROM comments - inner join member ON comments.comment_member_id = member.member_id - inner JOIN stat_projects ON comments.comment_target_id = stat_projects.project_id AND comments.comment_type = 0 - WHERE comments.comment_active = :comment_status - AND stat_projects.status = :project_status - AND comments.comment_member_id = :member_id - ORDER BY comments.comment_created_at DESC + `comment_id` + ,`comment_text` + ,`member`.`member_id` + ,`member`.`profile_image_url` + ,`comment_created_at` + ,`stat_projects`.`username` + ,`stat_projects`.`project_member_id` + ,`comment_target_id` + ,`stat_projects`.`title` + ,`stat_projects`.`project_id` + ,`stat_projects`.`laplace_score` + ,`stat_projects`.`count_likes` + ,`stat_projects`.`count_dislikes` + ,`stat_projects`.`image_small` + ,`stat_projects`.`version` + ,`stat_projects`.`cat_title` + ,`stat_projects`.`count_comments` + ,`stat_projects`.`changed_at` + ,`stat_projects`.`created_at` + FROM `comments` + INNER JOIN `member` ON `comments`.`comment_member_id` = `member`.`member_id` + INNER JOIN `stat_projects` ON `comments`.`comment_target_id` = `stat_projects`.`project_id` AND `comments`.`comment_type` = 0 + WHERE `comments`.`comment_active` = :comment_status + AND `stat_projects`.`status` = :project_status + AND `comments`.`comment_member_id` = :member_id + ORDER BY `comments`.`comment_created_at` DESC '; if (isset($limit)) { $sql .= ' limit ' . (int)$limit; } $result = $this->_db->fetchAll($sql, array( 'member_id' => $member_id, 'project_status' => Default_Model_DbTable_Project::PROJECT_ACTIVE, 'comment_status' => Default_Model_DbTable_Comments::COMMENT_ACTIVE )); return $result; } public function fetchCntSupporters($member_id) { $sql = ' SELECT DISTINCT `plings`.`member_id` FROM `plings` JOIN `project` ON `plings`.`project_id` = `project`.`project_id` JOIN `member` ON `project`.`member_id` = `member`.`member_id` WHERE `plings`.`status_id` = 2 AND `project`.`status` = :project_status AND `project`.`type_id` = 1 AND `project`.`member_id` = :member_id '; $result = - $this->_db->fetchAll($sql, array('member_id' => $member_id, 'project_status' => Default_Model_Project::PROJECT_ACTIVE)); + $this->_db->fetchAll($sql, + array('member_id' => $member_id, 'project_status' => Default_Model_Project::PROJECT_ACTIVE)); return count($result); } public function fetchSupporterDonationInfo($member_id) { - /*$sql = 'SELECT max(active_time) AS active_time_max - ,min(active_time) AS active_time_min + /*$sql = 'SELECT max(active_time) AS active_time_max + ,min(active_time) AS active_time_min ,(DATE_ADD(max(active_time), INTERVAL 1 YEAR) > now()) AS issupporter ,count(1) AS cnt from support where status_id = 2 AND type_id = 0 AND member_id = :member_id ';*/ $sql = " select member_id, max(active_time_max) as active_time_max, min(active_time_min) as active_time_min, max(is_valid) as issupporter, count(1) AS cnt from v_support where member_id = :member_id "; $result = $this->getAdapter()->fetchRow($sql, array('member_id' => $member_id)); return $result; } - - public function fetchSupporterSubscriptionInfo($member_id) { $sql = 'SELECT create_time,amount,period,period_frequency from support where status_id = 2 AND type_id = 1 AND member_id = :member_id ORDER BY create_time desc LIMIT 1'; $result = $this->getAdapter()->fetchRow($sql, array('member_id' => $member_id)); return $result; } public function fetchLastActiveTime($member_id) { $sql_page_views = "SELECT `created_at` AS `lastactive` FROM `stat_page_views` WHERE `member_id` = :member_id ORDER BY `created_at` DESC LIMIT 1"; $sql_activities = "SELECT `time` AS lastactive FROM activity_log WHERE member_id = :member_id ORDER BY `time` DESC LIMIT 1"; $result_page_views = $this->getAdapter()->fetchRow($sql_page_views, array('member_id' => $member_id)); $result_activities = $this->getAdapter()->fetchRow($sql_activities, array('member_id' => $member_id)); if (count($result_page_views) > 0 AND count($result_activities) > 0) { return $result_page_views['lastactive'] > $result_activities['lastactive'] ? $result_page_views['lastactive'] : $result_activities['lastactive']; } if (count($result_page_views) > count($result_activities)) { return $result_page_views['lastactive']; } if (count($result_activities) > count($result_page_views)) { return $result_activities['lastactive']; } return null; } /** * @param int $member_id * * @return array */ public function fetchContributedProjectsByCat($member_id) { $projects = $this->fetchSupportedProjects($member_id); $catArray = array(); if (count($projects) == 0) { return $catArray; } foreach ($projects as $pro) { $catArray[$pro->catTitle] = array(); } $helperProductUrl = new Default_View_Helper_BuildProductUrl(); foreach ($projects as $pro) { $projArr = array(); $projArr['id'] = $pro->project_id; $projArr['name'] = $pro->title; $projArr['image'] = $pro->image_small; $projArr['url'] = $helperProductUrl->buildProductUrl($pro->project_id, '', null, true); $projArr['sumAmount'] = $pro->sumAmount; array_push($catArray[$pro->catTitle], $projArr); } return $catArray; } /** * @param int $member_id * @param null $limit * * @return Zend_Db_Table_Rowset_Abstract */ public function fetchSupportedProjects($member_id, $limit = null) { $sql = " SELECT plings.project_id, project.title, project.image_small, project_category.title AS catTitle, (SELECT SUM(amount) FROM plings WHERE plings.project_id=project.project_id AND plings.status_id=2) AS sumAmount FROM plings JOIN project ON plings.project_id = project.project_id JOIN project_category ON project.project_category_id = project_category.project_category_id WHERE plings.status_id IN (2,3,4) AND plings.member_id = :member_id AND project.status = :project_status AND project.type_id = 1 GROUP BY plings.project_id ORDER BY sumAmount DESC "; if (null != $limit) { $sql .= $this->_db->quoteInto(" limit ?", $limit, 'INTEGER'); } $result = - $this->_db->fetchAll($sql, array('member_id' => $member_id, 'project_status' => Default_Model_Project::PROJECT_ACTIVE)); + $this->_db->fetchAll($sql, + array('member_id' => $member_id, 'project_status' => Default_Model_Project::PROJECT_ACTIVE)); return $this->generateRowSet($result); } /** * @param string $value * @param int $test_case_sensitive * * @param array $omitMember * * @return array */ public function findUsername($value, $test_case_sensitive = self::CASE_INSENSITIVE, $omitMember = array()) { $sql = " SELECT * FROM `member` "; if ($test_case_sensitive == self::CASE_INSENSITIVE) { $sql .= "WHERE LCASE(member.username) = LCASE(:username)"; } else { $sql .= "WHERE member.username = :username"; } if (count($omitMember) > 0) { $sql .= " AND member.member_id NOT IN (" . implode(',', $omitMember) . ")"; } return $this->_db->fetchAll($sql, array('username' => $value)); } /** * @param string $login * * @return int */ public function generateUniqueUsername($login) { $sql = "SELECT COUNT(*) AS `counter` FROM `member` WHERE `username` REGEXP CONCAT(:user_name,'[_0-9]*$')"; $result = $this->_db->fetchRow($sql, array('user_name' => $login)); return $login . '_' . $result['counter']; } /** - * @param int $member_id + * @param int $member_id * @param string $email * * @return bool * @throws Zend_Db_Statement_Exception */ public function setActive($member_id, $email) { $sql = " UPDATE `member` STRAIGHT_JOIN `member_email` ON `member`.`member_id` = `member_email`.`email_member_id` AND `member_email`.`email_checked` IS NULL AND `member`.`is_deleted` = 0 AND `member_email`.`email_deleted` = 0 SET `member`.`mail_checked` = 1, `member`.`is_active` = 1, `member`.`changed_at` = NOW(), `member_email`.`email_checked` = NOW() WHERE `member`.`member_id` = :memberId AND `member_email`.`email_address` = :mailAddress; "; $stmnt = $this->_db->query($sql, array('memberId' => $member_id, 'mailAddress' => $email)); return $stmnt->rowCount() > 0 ? true : false; } - /** - * @param int $member_id - * - * @throws Exception - * @deprecated since we're using solr server for searching - */ - private function removeMemberProjectsFromSearch($member_id) - { - $modelProject = new Default_Model_Project(); - $memberProjects = $modelProject->fetchAllProjectsForMember($member_id); - $modelSearch = new Default_Model_Search_Lucene(); - foreach ($memberProjects as $memberProject) { - $product = array(); - $product['project_id'] = $memberProject->project_id; - $product['project_category_id'] = $memberProject->project_category_id; - $modelSearch->deleteDocument($product); - } - } - /** * @param string $identity * * @return Zend_Db_Table_Row_Abstract */ public function findActiveMemberByMail($identity) { $sqlMail = " SELECT `m`.*, `me`.`email_address` AS `mail`, IF(ISNULL(`me`.`email_checked`),0,1) AS `mail_checked` FROM `member` AS `m` JOIN `member_email` AS `me` ON `me`.`email_member_id` = `m`.`member_id` AND `me`.`email_primary` = 1 WHERE `is_active` = :active AND `is_deleted` = :deleted AND `me`.`email_address` = :identity "; // test identity as mail $resultMail = $this->getAdapter()->fetchRow($sqlMail, - array('active' => self::MEMBER_ACTIVE, 'deleted' => self::MEMBER_NOT_DELETED, 'identity' => $identity)) - ; + array('active' => self::MEMBER_ACTIVE, 'deleted' => self::MEMBER_NOT_DELETED, 'identity' => $identity)); if ((false !== $resultMail) AND (count($resultMail) > 0)) { return $this->generateRowClass($resultMail); } return $this->createRow(); } - private function setDeletedInSubSystems($member_id) + public function getMembersAvatarOldAutogenerated($orderby = 'member_id desc', $limit = null, $offset = null) { - try { - $id_server = new Default_Model_Ocs_OAuth(); - $id_server->deleteUser($member_id); - Zend_Registry::get('logger')->debug(__METHOD__ . ' - oauth : ' . implode(PHP_EOL." - ", $id_server->getMessages())); - } catch (Exception $e) { - Zend_Registry::get('logger')->err($e->getMessage() . PHP_EOL . $e->getTraceAsString()); - } - try { - $ldap_server = new Default_Model_Ocs_Ldap(); - $ldap_server->deleteUser($member_id); - Zend_Registry::get('logger')->debug(__METHOD__ . ' - ldap : ' . implode(PHP_EOL." - ", $ldap_server->getMessages())); - } catch (Exception $e) { - Zend_Registry::get('logger')->err($e->getMessage() . PHP_EOL . $e->getTraceAsString()); - } - try { - $openCode = new Default_Model_Ocs_Gitlab(); - $openCode->blockUser($member_id); - $openCode->blockUserProjects($member_id); - Zend_Registry::get('logger')->debug(__METHOD__ . ' - opencode : ' . implode(PHP_EOL." - ", $openCode->getMessages())); - } catch (Exception $e) { - Zend_Registry::get('logger')->err($e->getMessage() . PHP_EOL . $e->getTraceAsString()); - } - try { - $forum = new Default_Model_Ocs_Forum(); - $forum->blockUser($member_id); - $forum->blockUserPosts($member_id); - Zend_Registry::get('logger')->debug(__METHOD__ . ' - forum : ' . implode(PHP_EOL." - ", $forum->getMessages())); - } catch (Exception $e) { - Zend_Registry::get('logger')->err($e->getMessage() . PHP_EOL . $e->getTraceAsString()); - } - } + $sql = " + SELECT * FROM `tmp_member_avatar_unknow` + "; - public function getMembersAvatarOldAutogenerated($orderby='member_id desc',$limit = null, $offset = null) - { - $sql = " - select * from tmp_member_avatar_unknow - "; - + if (isset($orderby)) { + $sql = $sql . ' order by ' . $orderby; + } - if(isset($orderby)){ - $sql = $sql.' order by '.$orderby; - } + if (isset($limit)) { + $sql .= ' limit ' . (int)$limit; + } - if (isset($limit)) { - $sql .= ' limit ' . (int)$limit; - } + if (isset($offset)) { + $sql .= ' offset ' . (int)$offset; + } - if (isset($offset)) { - $sql .= ' offset ' . (int)$offset; - } + $resultSet = $this->_db->fetchAll($sql); - $resultSet = $this->_db->fetchAll($sql); - return $resultSet; - } + return $resultSet; + } - public function getMembersAvatarOldAutogeneratedTotalCount() + public function getMembersAvatarOldAutogeneratedTotalCount() { $sql = " select count(1) as cnt from tmp_member_avatar_unknow "; - $result = $this->getAdapter()->query($sql, array())->fetchAll(); - return $result[0]['cnt']; + $result = $this->getAdapter()->query($sql, array())->fetchAll(); + + return $result[0]['cnt']; } public function updateAvatarTypeId($member_id, $type_id) { $sql = " update member set avatar_type_id = :type_id where member_id = :member_id "; - $this->getAdapter()->query($sql, array('type_id'=>$type_id,'member_id'=>$member_id)); + $this->getAdapter()->query($sql, array('type_id' => $type_id, 'member_id' => $member_id)); } - private function setActivatedInSubsystems($member_id) + /** + * @param $userData + * @param $uuidMember + * + * @return string + * @throws Exception + */ + protected function generateIdentIcon_old($userData, $uuidMember) { - try { - $id_server = new Default_Model_Ocs_OAuth(); - $id_server->updateUser($member_id); - Zend_Registry::get('logger')->debug(__METHOD__ . ' - oauth : ' . print_r($id_server->getMessages(), true)); - } catch (Exception $e) { - Zend_Registry::get('logger')->err($e->getMessage() . PHP_EOL . $e->getTraceAsString()); - } - try { - $ldap_server = new Default_Model_Ocs_Ldap(); - $ldap_server->createUser($member_id); - Zend_Registry::get('logger')->debug(__METHOD__ . ' - ldap : ' . implode(PHP_EOL." - ", $ldap_server->getMessages())); - } catch (Exception $e) { - Zend_Registry::get('logger')->err($e->getMessage() . PHP_EOL . $e->getTraceAsString()); - } - try { - $openCode = new Default_Model_Ocs_Gitlab(); - $openCode->unblockUser($member_id); - $openCode->unblockUserProjects($member_id); - Zend_Registry::get('logger')->debug(__METHOD__ . ' - opencode : ' . implode(PHP_EOL." - ", $openCode->getMessages())); - } catch (Exception $e) { - Zend_Registry::get('logger')->err($e->getMessage() . PHP_EOL . $e->getTraceAsString()); - } - try { - $forum = new Default_Model_Ocs_Forum(); - $forum->unblockUser($member_id); - $forum->unblockUserPosts($member_id); - Zend_Registry::get('logger')->debug(__METHOD__ . ' - forum : ' . implode(PHP_EOL." - ", $forum->getMessages())); - } catch (Exception $e) { - Zend_Registry::get('logger')->err($e->getMessage() . PHP_EOL . $e->getTraceAsString()); + $identIcon = new Local_Tools_Identicon(); + $tmpImagePath = IMAGES_UPLOAD_PATH . 'tmp/' . $uuidMember . '.png'; + imagepng($identIcon->renderIdentIcon(sha1($userData['mail']), 1100), $tmpImagePath); + + $imageService = new Default_Model_DbTable_Image(); + $imageFilename = $imageService->saveImageOnMediaServer($tmpImagePath); + + return $imageFilename; + } + + /** + * @param int $member_id + * + * @throws Exception + * @deprecated since we're using solr server for searching + */ + private function removeMemberProjectsFromSearch($member_id) + { + $modelProject = new Default_Model_Project(); + $memberProjects = $modelProject->fetchAllProjectsForMember($member_id); + $modelSearch = new Default_Model_Search_Lucene(); + foreach ($memberProjects as $memberProject) { + $product = array(); + $product['project_id'] = $memberProject->project_id; + $product['project_category_id'] = $memberProject->project_category_id; + $modelSearch->deleteDocument($product); } } } \ No newline at end of file diff --git a/application/modules/default/models/Ocs/Gitlab.php b/application/modules/default/models/Ocs/Gitlab.php index a59cc2c43..dca8ab07a 100644 --- a/application/modules/default/models/Ocs/Gitlab.php +++ b/application/modules/default/models/Ocs/Gitlab.php @@ -1,1348 +1,1381 @@ . * * Created: 19.06.2018 */ class Default_Model_Ocs_Gitlab { /** @var Zend_Cache_Core */ protected $cache; protected $config; protected $messages; + /** @var Zend_Http_Client */ protected $httpClient; /** * @inheritDoc */ public function __construct($config = null) { if (isset($config)) { $this->config = $config; } else { $this->config = Zend_Registry::get('config')->settings->server->opencode; } $uri = $this->config->host; - $this->httpClient = new Zend_Http_Client($uri, array('keepalive' => true, 'strictredirects' => true)); + $this->httpClient = $this->getHttpClient($uri); $this->cache = Zend_Registry::get('cache'); $this->messages = array(); } + /** + * @param $uri + * @return Zend_Http_Client + * @throws Default_Model_Ocs_Gitlab_Exception + */ + protected function getHttpClient($uri) + { + try { + return new Zend_Http_Client($uri, array('keepalive' => true, 'strictredirects' => true)); + } catch (Zend_Exception $e) { + throw new Default_Model_Ocs_Gitlab_Exception('Can not create http client for uri: ' . $uri, 0, $e); + } + } + /** * @param int|array $member_data * * @return bool * @throws Default_Model_Ocs_Exception * @throws Zend_Exception * @throws Zend_Http_Client_Exception * @throws Zend_Json_Exception */ public function unblockUserProjects($member_data) { if (is_int($member_data)) { $member_data = $this->getMemberData($member_data, false); } if (empty($member_data)) { return false; } $user = $this->getUser($member_data['external_id'], $member_data['username']); if (false === $user) { return false; } $uri = $this->config->host . "/api/v4/users/{$user['id']}/projects"; $method = Zend_Http_Client::GET; $uid = $member_data['member_id']; try { $response = $this->httpRequest($uri, $uid, $method); if (false === $response) { $this->messages[] = "Fail "; return false; } } catch (Zend_Exception $e) { $this->messages[] = "Fail " . $e->getMessage(); return false; } $memberLog = new Default_Model_MemberDeactivationLog(); foreach ($response as $project) { $log_data = - $memberLog->getLogEntries($member_data['member_id'], Default_Model_MemberDeactivationLog::OBJ_TYPE_GITLAB_PROJECT, + $memberLog->getLogEntries($member_data['member_id'], + Default_Model_MemberDeactivationLog::OBJ_TYPE_GITLAB_PROJECT, $project['id']); if (false === $log_data) { continue; } $object_data = json_decode($log_data['object_data'], true); $visibility = $object_data['visibility']; $uri = $this->config->host . "/api/v4/projects/{$project['id']}"; $method = Zend_Http_Client::PUT; $uid = $member_data['member_id']; $data = array('visibility' => $visibility); try { $response = $this->httpRequest($uri, $uid, $method, $data); if (false === $response) { $this->messages[] = "Fail " . $uri; continue; } } catch (Zend_Exception $e) { $this->messages[] = "Fail " . $e->getMessage(); return false; } $this->messages[] = "Successful unblock user project: {$project['id']}"; - $memberLog->deleteLog($member_data['member_id'], Default_Model_MemberDeactivationLog::OBJ_TYPE_GITLAB_PROJECT, + $memberLog->deleteLog($member_data['member_id'], + Default_Model_MemberDeactivationLog::OBJ_TYPE_GITLAB_PROJECT, $project['id']); } return true; } /** * @param int $member_id * * @param bool $onlyActive * * @return array * @throws Default_Model_Ocs_Exception */ private function getMemberData($member_id, $onlyActive = true) { $onlyActiveFilter = ''; if ($onlyActive) { $onlyActiveFilter = " AND `m`.`is_active` = 1 AND `m`.`is_deleted` = 0 AND `me`.`email_checked` IS NOT NULL AND `me`.`email_deleted` = 0"; } $sql = " SELECT `mei`.`external_id`,`m`.`member_id`, `m`.`username`, `me`.`email_address`, `m`.`password`, `m`.`roleId`, `m`.`firstname`, `m`.`lastname`, `m`.`profile_image_url`, `m`.`biography`, `m`.`created_at`, `m`.`changed_at`, `m`.`source_id` FROM `member` AS `m` LEFT JOIN `member_email` AS `me` ON `me`.`email_member_id` = `m`.`member_id` AND `me`.`email_primary` = 1 LEFT JOIN `member_external_id` AS `mei` ON `mei`.`member_id` = `m`.`member_id` WHERE `m`.`member_id` = :memberId {$onlyActiveFilter} ORDER BY `m`.`member_id` DESC "; $result = Zend_Db_Table::getDefaultAdapter()->fetchRow($sql, array('memberId' => $member_id)); if (count($result) == 0) { throw new Default_Model_Ocs_Exception('member with id ' . $member_id . ' could not found.'); } return $result; } /** * @param $extern_uid * @param $username * * @return array|false * @throws Default_Model_Ocs_Exception * @throws Zend_Exception * @throws Zend_Http_Client_Exception * @throws Zend_Json_Exception */ public function getUser($extern_uid, $username) { $user_by_uid = $this->getUserByExternUid($extern_uid); if (false === empty($user_by_uid)) { return $user_by_uid; } $this->messages[] = "external id not found. external_id: " . $extern_uid; $user_by_dn = $this->getUserByDN(urlencode($username)); if (false === empty($user_by_dn)) { return $user_by_dn; } $this->messages[] = "ldap dn not found. username: " . $username; $user_by_name = $this->getUserWithName(urlencode($username)); if (false === empty($user_by_name)) { return $user_by_name; } $this->messages[] = "username not found. username: " . $username; return false; } /** * @param string $extern_uid * * @return array * @throws Default_Model_Ocs_Exception * @throws Zend_Exception * @throws Zend_Http_Client_Exception * @throws Zend_Json_Exception */ public function getUserByExternUid($extern_uid) { - $this->httpClient->resetParameters(); $uri = $this->config->host . "/api/v4/users?extern_uid={$extern_uid}&provider=" . $this->config->provider_name; $this->httpClient->setUri($uri); $this->httpClient->setHeaders('Private-Token', $this->config->private_token); $this->httpClient->setHeaders('Sudo', $this->config->user_sudo); $this->httpClient->setHeaders('User-Agent', $this->config->user_agent); $this->httpClient->setMethod(Zend_Http_Client::GET); $response = $this->httpClient->request(); $body = Zend_Json::decode($response->getRawBody()); if (count($body) == 0) { return array(); } if (array_key_exists("message", $body)) { $result_code = substr(trim($body["message"]), 0, 3); if ((int)$result_code >= 300) { throw new Default_Model_Ocs_Exception($body["message"]); } } Zend_Registry::get('logger')->debug(__METHOD__ . " - body: " . $response->getRawBody()); return $body[0]; } /** * @param $username * * @return array * @throws Default_Model_Ocs_Exception * @throws Zend_Exception * @throws Zend_Http_Client_Exception * @throws Zend_Json_Exception */ public function getUserByDN($username) { $user_id = $this->buildUserDn($username); $this->httpClient->resetParameters(); $uri = $this->config->host . "/api/v4/users?extern_uid={$user_id}&provider=ldapmain"; $this->httpClient->setUri($uri); $this->httpClient->setHeaders('Private-Token', $this->config->private_token); $this->httpClient->setHeaders('Sudo', $this->config->user_sudo); $this->httpClient->setHeaders('User-Agent', $this->config->user_agent); $this->httpClient->setMethod(Zend_Http_Client::GET); $response = $this->httpClient->request(); $body = Zend_Json::decode($response->getRawBody()); if (count($body) == 0) { return array(); } if (array_key_exists("message", $body)) { $result_code = substr(trim($body["message"]), 0, 3); if ((int)$result_code >= 300) { throw new Default_Model_Ocs_Exception($body["message"]); } } Zend_Registry::get('logger')->debug(__METHOD__ . " - body: " . $response->getRawBody()); return $body[0]; } /** * @param string $extern_uid * * @return string * @throws Zend_Exception */ private function buildUserDn($extern_uid) { $username = mb_strtolower($extern_uid); $baseDn = Default_Model_Ocs_Ldap::getBaseDn(); $dn = "cn={$username},{$baseDn}"; return $dn; } /** * @param string $username * * @return array * @throws Default_Model_Ocs_Exception * @throws Zend_Http_Client_Exception * @throws Zend_Json_Exception */ public function getUserWithName($username) { $this->httpClient->resetParameters(); $uri = $this->config->host . "/api/v4/users?username=" . $username; $this->httpClient->setUri($uri); $this->httpClient->setHeaders('Private-Token', $this->config->private_token); $this->httpClient->setHeaders('Sudo', $this->config->user_sudo); $this->httpClient->setHeaders('User-Agent', $this->config->user_agent); $this->httpClient->setMethod(Zend_Http_Client::GET); $response = $this->httpClient->request(); $body = Zend_Json::decode($response->getRawBody()); if (count($body) == 0) { return array(); } if (array_key_exists("message", $body)) { $result_code = substr(trim($body["message"]), 0, 3); if ((int)$result_code >= 300) { throw new Default_Model_Ocs_Exception($body["message"]); } } return $body[0]; } /** * @param string $uri * @param string $uid * @param string $method * @param array|null $post_param * * @return bool|array * @throws Zend_Http_Client_Exception * @throws Zend_Json_Exception + * @throws Zend_Uri_Exception */ protected function httpRequest($uri, $uid, $method = Zend_Http_Client::GET, $post_param = null) { $this->httpClient->resetParameters(); $this->httpClient->setUri($uri); $this->httpClient->setHeaders('Private-Token', $this->config->private_token); $this->httpClient->setHeaders('Sudo', $this->config->user_sudo); $this->httpClient->setHeaders('User-Agent', $this->config->user_agent); $this->httpClient->setMethod($method); if (isset($post_param)) { $this->httpClient->setParameterPost($post_param); } $response = $this->httpClient->request(); if ($response->getStatus() < 200 OR $response->getStatus() >= 500) { $this->messages[] = 'Request failed.(' . $uri . ') OCS Forum server send message: ' . $response->getBody(); return false; } $body = Zend_Json::decode($response->getBody()); if ($body && is_array($body) && array_key_exists("message", $body)) { $this->messages[] = "id: {$uid} ($uri) - " . Zend_Json::encode($body["message"]); } return $body; } public function blockUserProjects($member_data) { if (is_int($member_data)) { $member_data = $this->getMemberData($member_data, false); } if (empty($member_data)) { return false; } $user = $this->getUser($member_data['external_id'], $member_data['username']); if (false === $user) { return false; } $uri = $this->config->host . "/api/v4/users/{$user['id']}/projects"; $method = Zend_Http_Client::GET; $uid = $member_data['member_id']; try { $response = $this->httpRequest($uri, $uid, $method); if (false === $response) { $this->messages[] = "Fail "; return false; } } catch (Zend_Exception $e) { $this->messages[] = "Fail " . $e->getMessage(); return false; } foreach ($response as $project) { $memberLog = new Default_Model_MemberDeactivationLog(); - $memberLog->addLogData($member_data['member_id'], Default_Model_MemberDeactivationLog::OBJ_TYPE_GITLAB_PROJECT, + $memberLog->addLogData($member_data['member_id'], + Default_Model_MemberDeactivationLog::OBJ_TYPE_GITLAB_PROJECT, $project['id'], json_encode($project)); $uri = $this->config->host . "/api/v4/projects/{$project['id']}"; $method = Zend_Http_Client::PUT; $uid = $member_data['member_id']; $data = array('visibility' => 'private'); try { $response = $this->httpRequest($uri, $uid, $method, $data); if (false === $response) { $this->messages[] = "Fail " . $uri; continue; } } catch (Zend_Exception $e) { $this->messages[] = "Fail " . $e->getMessage(); return false; } $this->messages[] = "Successful block user project: {$project['id']}"; } return true; } /** * @param int|array $member_data * * @return bool * @throws Default_Model_Ocs_Exception * @throws Zend_Exception * @throws Zend_Http_Client_Exception * @throws Zend_Json_Exception */ public function blockUser($member_data) { if (is_int($member_data)) { $member_data = $this->getMemberData($member_data, false); } if (empty($member_data)) { return false; } $user = $this->getUser($member_data['external_id'], $member_data['username']); if (false === $user) { return false; } $uri = $this->config->host . "/api/v4/users/{$user['id']}/block"; $method = Zend_Http_Client::POST; $uid = $member_data['member_id']; try { $response = $this->httpRequest($uri, $uid, $method); if (false === $response) { $this->messages[] = "Fail "; return false; } } catch (Zend_Exception $e) { $this->messages[] = "Fail " . $e->getMessage(); return false; } $this->messages[] = "Successful block user: {$member_data['username']}"; $memberLog = new Default_Model_MemberDeactivationLog(); - $memberLog->addLog($member_data['member_id'], Default_Model_MemberDeactivationLog::OBJ_TYPE_GITLAB_USER, $user['id']); + $memberLog->addLog($member_data['member_id'], Default_Model_MemberDeactivationLog::OBJ_TYPE_GITLAB_USER, + $user['id']); return true; } /** * @param int|array $member_data * * @return bool * @throws Default_Model_Ocs_Exception * @throws Zend_Exception * @throws Zend_Http_Client_Exception * @throws Zend_Json_Exception */ public function unblockUser($member_data) { if (is_int($member_data)) { $member_data = $this->getMemberData($member_data, false); } if (empty($member_data)) { return false; } $user = $this->getUser($member_data['external_id'], $member_data['username']); if (false === $user) { return false; } $uri = $this->config->host . "/api/v4/users/{$user['id']}/unblock"; $method = Zend_Http_Client::POST; $uid = $member_data['member_id']; try { $response = $this->httpRequest($uri, $uid, $method); if (false === $response) { $this->messages[] = "Fail "; return false; } } catch (Zend_Exception $e) { $this->messages[] = "Fail " . $e->getMessage(); return false; } $this->messages[] = "Successful unblock user: {$member_data['username']}"; $memberLog = new Default_Model_MemberDeactivationLog(); - $memberLog->deleteLog($member_data['member_id'], Default_Model_MemberDeactivationLog::OBJ_TYPE_GITLAB_USER, $user['id']); + $memberLog->deleteLog($member_data['member_id'], Default_Model_MemberDeactivationLog::OBJ_TYPE_GITLAB_USER, + $user['id']); return true; } /** * @param $member_data * @param $oldUsername * * @return array|bool|null * @throws Default_Model_Ocs_Exception * @throws Zend_Exception * @throws Zend_Http_Client_Exception * @throws Zend_Json_Exception */ public function updateUserFromArray($member_data, $oldUsername) { if (empty($member_data)) { return false; } $this->messages = array(); $data = $this->mapUserData($member_data); $user = $this->getUser($data['extern_uid'], $oldUsername); if (false === $user) { $this->messages[] = "Fail"; return false; } // $data['skip_reconfirmation'] = 'true'; // unset($data['password']); try { foreach ($data as $datum) { $datum['skip_reconfirmation'] = 'true'; unset($datum['password']); $this->httpUserUpdate($data, $user['id']); } } catch (Zend_Exception $e) { $this->messages[] = "Fail " . $e->getMessage(); return false; } $this->messages[] = "overwritten : " . json_encode($user); return $user; } /** * @param array $user * * @return array * @throws Zend_Exception */ protected function mapUserData($user) { $paramEmail = ''; if (isset($user['email_address'])) { $paramEmail = $user['email_address']; - } else if (isset($user['mail'])) { - $paramEmail = $user['mail']; + } else { + if (isset($user['mail'])) { + $paramEmail = $user['mail']; + } } if (strlen($user['biography']) > 254) { $helperTruncate = new Default_View_Helper_Truncate(); $bio = $helperTruncate->truncate($user['biography'], 250); } else { $bio = empty($user['biography']) ? '' : $user['biography']; } $data = array( array( 'email' => $paramEmail, 'username' => mb_strtolower($user['username']), // 'name' => (false == empty($user['lastname'])) ? trim($user['firstname'] . ' ' . $user['lastname']) : $user['username'], 'name' => $user['username'], 'password' => $user['password'], 'provider' => $this->config->provider_name, 'extern_uid' => $user['external_id'], 'bio' => $bio, 'admin' => $user['roleId'] == 100 ? 'true' : 'false', 'can_create_group' => 'true' ), array( 'email' => $paramEmail, 'username' => mb_strtolower($user['username']), // 'name' => (false == empty($user['lastname'])) ? trim($user['firstname'] . ' ' . $user['lastname']) : $user['username'], 'name' => $user['username'], 'password' => $user['password'], 'provider' => "ldapmain", 'extern_uid' => $this->buildUserDn($user['username']), 'bio' => $bio, 'admin' => $user['roleId'] == 100 ? 'true' : 'false', 'can_create_group' => 'true' ) ); return $data; } /** * @param $data * * @param $id * * @return bool * @throws Zend_Exception * @throws Zend_Http_Client_Exception * @throws Zend_Http_Exception */ private function httpUserUpdate($data, $id) { $this->httpClient->resetParameters(); - $uri = $this->config->host . $this->config->url->user_create . '/' . $id; + $uri = $this->config->host . '/api/v4/users/' . $id; $this->httpClient->setUri($uri); $this->httpClient->setHeaders('Private-Token', $this->config->private_token); $this->httpClient->setHeaders('Sudo', $this->config->user_sudo); $this->httpClient->setHeaders('User-Agent', $this->config->user_agent); $this->httpClient->setMethod(Zend_Http_Client::PUT); $this->httpClient->setParameterPost($data); $response = $this->httpClient->request(); if ($response->getStatus() < 200 OR $response->getStatus() >= 300) { throw new Default_Model_Ocs_Exception('update user data failed. OCS OpenCode server send message: ' - . $response->getRawBody()); + . $response->getRawBody()); } $body = Zend_Json::decode($response->getRawBody()); if (array_key_exists("message", $body)) { throw new Default_Model_Ocs_Exception($body["message"]); } Zend_Registry::get('logger')->debug(__METHOD__ . ' - request: ' . $uri); Zend_Registry::get('logger')->debug(__METHOD__ . ' - response: ' . $response->getRawBody()); return $body; } /** * @param string $email * * @return array * @throws Default_Model_Ocs_Exception * @throws Zend_Exception * @throws Zend_Http_Client_Exception * @throws Zend_Json_Exception */ public function getUserByEmail($email) { $this->httpClient->resetParameters(); $uri = $this->config->host . "/api/v4/users?search={$email}"; $this->httpClient->setUri($uri); $this->httpClient->setHeaders('Private-Token', $this->config->private_token); $this->httpClient->setHeaders('Sudo', $this->config->user_sudo); $this->httpClient->setHeaders('User-Agent', $this->config->user_agent); $this->httpClient->setMethod(Zend_Http_Client::GET); $response = $this->httpClient->request(); $body = Zend_Json::decode($response->getRawBody()); if (count($body) == 0) { return array(); } if (array_key_exists("message", $body)) { $result_code = substr(trim($body["message"]), 0, 3); if ((int)$result_code >= 300) { throw new Default_Model_Ocs_Exception($body["message"]); } } Zend_Registry::get('logger')->debug(__METHOD__ . " - body: " . $response->getRawBody()); return $body; } /** * @param array $member * @param array $userSubsystem * * @return array * @throws Zend_Exception */ public function validateUserData($member, $userSubsystem) { $userDn = $this->buildUserDn(strtolower($member['username'])); $result = array(); if (mb_strtolower($member['email_address']) != $userSubsystem['email']) { $result[] = 'email_address<=>email'; $result[] = $member['email_address'] . '<=>' . $userSubsystem['email']; } if (mb_strtolower($member['username']) != $userSubsystem['username']) { $result[] = 'username<=>username'; $result[] = mb_strtolower($member['username']) . '<=>' . $userSubsystem['username']; } if ($member['username'] != $userSubsystem['name']) { $result[] = 'username<=>name'; $result[] = $member['username'] . '<=>' . $userSubsystem['name']; } if (($member['roleId'] == 100 ? true : false) != $userSubsystem['is_admin']) { $result[] = 'roleId<=>admin'; $result[] = $member['roleId'] . '<=>' . $userSubsystem['admin']; } if ("active" != $userSubsystem['state']) { $result[] = 'is_active<=>state'; $result[] = ($member['is_active'] ? 'active' : 'inactive') . '<=>' . $userSubsystem['state']; } if (false === array_search('oauth_opendesktop', array_column($userSubsystem['identities'], 'provider'))) { $result[] = 'oauth_opendesktop missing'; } $provider = array_column($userSubsystem['identities'], 'extern_uid', 'provider'); $providerOauth = isset($provider['oauth_opendesktop']) ? $provider['oauth_opendesktop'] : ''; if ($member['external_id'] != $providerOauth) { $result[] = 'external_id<=>oauth_opendesktop->extern_uid'; $result[] = $member['external_id'] . '<=>' . $providerOauth; } if (false === array_search('ldapmain', array_column($userSubsystem['identities'], 'provider'))) { $result[] = 'ldapmain missing'; } $providerLdap = isset($provider['ldapmain']) ? $provider['ldapmain'] : ''; if ($userDn != $providerLdap) { $result[] = 'userDn<=>ldapmain->extern_uid'; $result[] = $userDn . '<=>' . $providerLdap; } return $result; } public function resetMessages() { $this->messages = array(); } /** * @param $member_data * * @param bool $force * * @return array|bool * @throws Zend_Exception * @throws Zend_Http_Client_Exception * @throws Zend_Json_Exception */ public function createUserFromArray($member_data, $force = false) { if (empty($member_data)) { return false; } $this->messages = array(); $data = $this->mapUserData($member_data); $user = $this->getUser($member_data['external_id'], $member_data['username']); $updatedUser = null; if (false === $user) { try { $data[0]['skip_confirmation'] = 'true'; $user = $this->httpUserCreate($data[0]); $this->messages[] = "created : " . json_encode($user); $data[1]['skip_reconfirmation'] = 'true'; $updatedUser = $this->httpUserUpdate($data[1], $user['id']); $this->messages[] = "updated : " . json_encode($updatedUser); } catch (Zend_Exception $e) { $this->messages[] = "Fail " . $e->getMessage(); return false; } return $updatedUser; } if ($force === true) { try { foreach ($data as $datum) { $datum['skip_reconfirmation'] = 'true'; unset($datum['password']); $updatedUser = $this->httpUserUpdate($datum, $user['id']); } } catch (Zend_Exception $e) { $this->messages[] = "Fail " . $e->getMessage(); return false; } $this->messages[] = "overwritten : " . json_encode($updatedUser); return $updatedUser; } $this->messages[0] = 'user already exists.'; return false; } /** * @param $data * * @return bool * @throws Default_Model_Ocs_Exception * @throws Zend_Exception * @throws Zend_Http_Client_Exception * @throws Zend_Json_Exception */ private function httpUserCreate($data) { $this->httpClient->resetParameters(); - $uri = $this->config->host . $this->config->url->user_create; + $uri = $this->config->host . '/api/v4/users'; $this->httpClient->setUri($uri); $this->httpClient->setHeaders('Private-Token', $this->config->private_token); $this->httpClient->setHeaders('Sudo', $this->config->user_sudo); $this->httpClient->setHeaders('User-Agent', $this->config->user_agent); $this->httpClient->setMethod(Zend_Http_Client::POST); $this->httpClient->setParameterPost($data); $response = $this->httpClient->request(); if ($response->getStatus() < 200 OR $response->getStatus() >= 300) { throw new Default_Model_Ocs_Exception('push user data failed. OCS OpenCode server send message: ' - . $response->getRawBody()); + . $response->getRawBody()); } $body = Zend_Json::decode($response->getRawBody()); if (array_key_exists("message", $body)) { throw new Default_Model_Ocs_Exception(Zend_Json::encode($body["message"])); } Zend_Registry::get('logger')->debug(__METHOD__ . ' - request: ' . $uri); Zend_Registry::get('logger')->debug(__METHOD__ . ' - response: ' . $response->getRawBody()); return $body; } /** - * @param int $member_id + * @param int $member_id * * @return bool * @throws Zend_Exception * @throws Zend_Http_Client_Exception * @throws Zend_Http_Exception * @throws Zend_Json_Exception */ public function deleteUser($member_id) { if (empty($member_id)) { return false; } $member_data = $this->getMemberData($member_id, false); $user = $this->getUser($member_data['external_id'], mb_strtolower($member_data['username'])); if (false === $user) { $this->messages[0] = 'Not deleted. User not exists. '; return false; } return $this->httpUserDelete($user['id']); } /** * @param $id * * @return bool * @throws Zend_Exception * @throws Zend_Http_Client_Exception * @throws Zend_Http_Exception */ private function httpUserDelete($id) { $this->httpClient->resetParameters(); $uri = $this->config->host . '/api/v4/users/' . $id; $this->httpClient->setUri($uri); $this->httpClient->setHeaders('Private-Token', $this->config->private_token); $this->httpClient->setHeaders('Sudo', $this->config->user_sudo); $this->httpClient->setHeaders('User-Agent', $this->config->user_agent); $this->httpClient->setMethod(Zend_Http_Client::DELETE); $response = $this->httpClient->request(); if (204 == $response->getStatus()) { $this->messages[0] = ' - response : ' . $response->getRawBody() . " - user id: {$id}"; return true; } if ($response->getStatus() < 200 AND $response->getStatus() >= 300) { throw new Default_Model_Ocs_Exception('delete user failed. OCS OpenCode server send message: ' . $response->getRawBody() - . PHP_EOL . " - OpenCode user id: {$id}"); + . PHP_EOL . " - OpenCode user id: {$id}"); } $body = Zend_Json::decode($response->getRawBody()); if (array_key_exists("message", $body)) { throw new Default_Model_Ocs_Exception($body["message"]); } Zend_Registry::get('logger')->debug(__METHOD__ . ' - request: ' . $uri); Zend_Registry::get('logger')->debug(__METHOD__ . ' - response: ' . $response->getRawBody()); $this->messages[0] = ' - response : ' . $response->getRawBody() . " - user id: {$id}"; return true; } /** * @param string $username * * @return bool * @throws Zend_Exception * @throws Zend_Http_Client_Exception * @throws Zend_Json_Exception */ public function userExists($username) { $this->httpClient->resetParameters(); $uri = $this->config->host . '/api/v4/users?username=' . $username; $this->httpClient->setUri($uri); $this->httpClient->setHeaders('Private-Token', $this->config->private_token); $this->httpClient->setHeaders('Sudo', $this->config->user_sudo); $this->httpClient->setHeaders('User-Agent', $this->config->user_agent); $this->httpClient->setMethod(Zend_Http_Client::GET); $response = $this->httpClient->request(); $body = Zend_Json::decode($response->getRawBody()); if (array_key_exists("message", $body)) { throw new Default_Model_Ocs_Exception($body["message"]); } if (count($body) == 0) { return false; } Zend_Registry::get('logger')->debug(__METHOD__ . ' - request: ' . $uri); Zend_Registry::get('logger')->debug(__METHOD__ . ' - response: ' . $response->getBody()); if ($response->getStatus() < 200 AND $response->getStatus() >= 300) { throw new Zend_Exception('exists user failed. OCS OpenCode server send message: ' . $response->getBody() . PHP_EOL - . " - OpenCode user id: {$username}"); + . " - OpenCode user id: {$username}"); } $this->messages[0] = ' - response for user exists request: ' . $response->getBody() . PHP_EOL . " - OpenCode user id: {$username}" . PHP_EOL; return $body[0]['id']; } /** * @return array|null */ public function getMessages() { return $this->messages; } /** * @param int $member_id * * @return array|bool * @throws Zend_Exception * @throws Zend_Http_Client_Exception * @throws Zend_Json_Exception */ public function createUser($member_id) { if (empty($member_id)) { return false; } $member_data = $this->getMemberData($member_id); $data = $this->mapUserData($member_data); $userId = $this->getUser($data['extern_uid'], $data['username']); if (false === $userId) { try { $data[0]['skip_confirmation'] = 'true'; $user = $this->httpUserCreate($data[0]); $this->messages[] = "created : " . json_encode($user); $data[1]['skip_reconfirmation'] = 'true'; $updatedUser = $this->httpUserUpdate($data[1], $user['id']); $this->messages[] = "updated : " . json_encode($updatedUser); } catch (Zend_Exception $e) { $this->messages[] = "Fail " . $e->getMessage(); return false; } $this->messages[] = "Success"; return $data; } $this->messages[0] = 'user already exists.'; return false; } /** * @param string $name * * @return bool * @throws Zend_Exception * @throws Zend_Http_Client_Exception * @throws Zend_Json_Exception */ public function groupExists($name) { $this->httpClient->resetParameters(); $uri = $this->config->host . '/api/v4/groups?search=' . $name; $this->httpClient->setUri($uri); $this->httpClient->setHeaders('Private-Token', $this->config->private_token); $this->httpClient->setHeaders('Sudo', $this->config->user_sudo); $this->httpClient->setHeaders('User-Agent', $this->config->user_agent); $this->httpClient->setMethod(Zend_Http_Client::GET); $response = $this->httpClient->request(); - $body = Zend_Json::decode($response->getRawBody()); + try { + $body = Zend_Json::decode($response->getRawBody()); + } catch (Zend_Json_Exception $e) { + throw new Default_Model_Ocs_Exception($e,0, $e); + } catch (Zend_Http_Client_Exception $e) { + // Gitlab send empty response when group not found, this cause an Exception in http client + // we cannot distinguish between a real error and a successful empty response + // so we catch this exception and log only + // TODO: maybe use plain curl request + error_log($e->getMessage()); + } if (count($body) > 0) { return true; } if (array_key_exists("message", $body)) { $result_code = substr(trim($body["message"]), 0, 3); if ((int)$result_code >= 300) { throw new Default_Model_Ocs_Exception($body["message"]); } } if (array_key_exists("error_description", $body)) { throw new Default_Model_Ocs_Exception($body["error_description"]); } return false; } /** * @param $member_id * * @return bool * @throws Default_Model_Ocs_Exception * @throws Zend_Exception * @throws Zend_Http_Client_Exception * @throws Zend_Http_Exception * @throws Zend_Json_Exception */ public function updateMail($member_id) { if (empty($member_id)) { throw new Default_Model_Ocs_Exception('given member_id is empty'); } $member_data = $this->getMemberData($member_id, false); $entry = $this->getUser($member_data['external_id'], $member_data['username']); if (false === $entry) { $this->messages[] = "Failed. User not found;"; return false; } $entry['skip_reconfirmation'] = 'true'; $entry['email'] = $member_data['email_address']; unset($entry['password']); $this->httpUserUpdate($entry, $entry['id']); $this->messages[] = "Success"; return true; } /** * @return array|mixed * @throws Default_Model_Ocs_Exception * @throws Zend_Http_Client_Exception * @throws Zend_Json_Exception */ public function getUsers() { $this->httpClient->resetParameters(); $uri = $this->config->host . "/api/v4/users"; $this->httpClient->setUri($uri); $this->httpClient->setHeaders('Private-Token', $this->config->private_token); $this->httpClient->setHeaders('Sudo', $this->config->user_sudo); $this->httpClient->setHeaders('User-Agent', $this->config->user_agent); $this->httpClient->setMethod(Zend_Http_Client::GET); $response = $this->httpClient->request(); $body = Zend_Json::decode($response->getRawBody()); if (count($body) == 0) { return array(); } if (array_key_exists("message", $body)) { $result_code = substr(trim($body["message"]), 0, 3); if ((int)$result_code >= 300) { throw new Default_Model_Ocs_Exception($body["message"]); } } return $body; } /** * @param int $id * * @return array|mixed * @throws Default_Model_Ocs_Exception * @throws Zend_Http_Client_Exception * @throws Zend_Json_Exception */ public function getUserWithId($id) { $this->httpClient->resetParameters(); $uri = $this->config->host . "/api/v4/users/" . $id; $this->httpClient->setUri($uri); $this->httpClient->setHeaders('Private-Token', $this->config->private_token); $this->httpClient->setHeaders('Sudo', $this->config->user_sudo); $this->httpClient->setHeaders('User-Agent', $this->config->user_agent); $this->httpClient->setMethod(Zend_Http_Client::GET); $response = $this->httpClient->request(); $body = Zend_Json::decode($response->getRawBody()); if (count($body) == 0) { return array(); } if (array_key_exists("message", $body)) { $result_code = substr(trim($body["message"]), 0, 3); if ((int)$result_code >= 300) { throw new Default_Model_Ocs_Exception($body["message"]); } } return $body; } /** * @param int $page * @param int $limit * @param string $order_by * @param string $sort * * @return array|false|mixed * @throws Zend_Http_Client_Exception */ public function getProjects($page = 1, $limit = 5, $order_by = 'created_at', $sort = 'desc') { $cache = $this->cache; $cacheName = __FUNCTION__; if (!($body = $cache->load($cacheName))) { $this->httpClient->resetParameters(); $uri = $this->config->host . '/api/v4/projects?order_by=' . $order_by . '&sort=' . $sort . '&visibility=public&page=' . $page . '&per_page=' . $limit; $this->httpClient->setUri($uri); $this->httpClient->setHeaders('Private-Token', $this->config->private_token); $this->httpClient->setHeaders('Sudo', $this->config->user_sudo); $this->httpClient->setHeaders('User-Agent', $this->config->user_agent); $this->httpClient->setMethod(Zend_Http_Client::GET); try { $response = $this->httpClient->request(); $body = Zend_Json::decode($response->getRawBody()); if (count($body) == 0) { return array(); } if (array_key_exists("message", $body)) { $result_code = substr(trim($body["message"]), 0, 3); if ((int)$result_code >= 300) { throw new Default_Model_Ocs_Exception($body["message"]); } } //fetch also user data $returnArray = array(); foreach ($body as $git_project) { $gituser = $this->getUserWithName($git_project['namespace']['name']); $git_project['namespace']['avatar_url'] = $gituser['avatar_url']; $returnArray[] = $git_project; } $body = $returnArray; } catch (Exception $exc) { return array(); } } return $body; } /** * @param int $id * * @return mixed|null * @throws Default_Model_Ocs_Exception * @throws Zend_Http_Client_Exception * @throws Zend_Json_Exception */ public function getProject($id) { $this->httpClient->resetParameters(); $uri = $this->config->host . "/api/v4/projects/" . $id . "/"; $this->httpClient->setUri($uri); $this->httpClient->setHeaders('Private-Token', $this->config->private_token); $this->httpClient->setHeaders('Sudo', $this->config->user_sudo); $this->httpClient->setHeaders('User-Agent', $this->config->user_agent); $this->httpClient->setMethod(Zend_Http_Client::GET); $response = $this->httpClient->request(); $body = Zend_Json::decode($response->getRawBody()); if ($body['visibility'] <> 'public') { throw new Default_Model_Ocs_Exception('Project not found in gitlab'); } if (count($body) == 0) { return null; } if (array_key_exists("message", $body)) { $result_code = substr(trim($body["message"]), 0, 3); if ((int)$result_code >= 300) { throw new Default_Model_Ocs_Exception($body["message"]); } } return $body; } /** * @param int $id * @param string $state * @param int $page * @param int $limit * * @return array|mixed * @throws Default_Model_Ocs_Exception * @throws Zend_Http_Client_Exception * @throws Zend_Json_Exception */ public function getProjectIssues($id, $state = 'opened', $page = 1, $limit = 5) { $this->httpClient->resetParameters(); $uri = $this->config->host . '/api/v4/projects/' . $id . '/issues?state=' . $state . '&page=' . $page . '&per_page=' . $limit; $this->httpClient->setUri($uri); $this->httpClient->setHeaders('Private-Token', $this->config->private_token); $this->httpClient->setHeaders('Sudo', $this->config->user_sudo); $this->httpClient->setHeaders('User-Agent', $this->config->user_agent); $this->httpClient->setMethod(Zend_Http_Client::GET); $response = $this->httpClient->request(); $body = Zend_Json::decode($response->getRawBody()); if (count($body) == 0) { return array(); } if (array_key_exists("message", $body)) { $result_code = substr(trim($body["message"]), 0, 3); if ((int)$result_code >= 300) { throw new Default_Model_Ocs_Exception($body["message"]); } } return $body; } /** * @param int $user_id * @param int $page * @param int $limit * * @return array|mixed * @throws Default_Model_Ocs_Exception * @throws Zend_Http_Client_Exception * @throws Zend_Json_Exception */ public function getUserProjects($user_id, $page = 1, $limit = 50) { $this->httpClient->resetParameters(); $uri = $this->config->host . '/api/v4/users/' . $user_id . '/projects?visibility=public&page=' . $page . '&per_page=' . $limit; $this->httpClient->setUri($uri); $this->httpClient->setHeaders('Private-Token', $this->config->private_token); $this->httpClient->setHeaders('Sudo', $this->config->user_sudo); $this->httpClient->setHeaders('User-Agent', $this->config->user_agent); $this->httpClient->setMethod(Zend_Http_Client::GET); $response = null; try { $response = $this->httpClient->request(); - + } catch (Exception $ex) { $response = null; } - - if($response && !empty($response)) { + + if ($response && !empty($response)) { $body = Zend_Json::decode($response->getRawBody()); if (count($body) == 0) { return array(); } if (array_key_exists("message", $body)) { $result_code = substr(trim($body["message"]), 0, 3); if ((int)$result_code >= 300) { throw new Default_Model_Ocs_Exception($body["message"]); } } + return $body; } return null; } } \ No newline at end of file diff --git a/application/modules/default/models/Ocs/Gitlab/Exception.php b/application/modules/default/models/Ocs/Gitlab/Exception.php new file mode 100644 index 000000000..9b109c5ab --- /dev/null +++ b/application/modules/default/models/Ocs/Gitlab/Exception.php @@ -0,0 +1,28 @@ +. + * + * Created: 19.06.2018 + */ +class Default_Model_Ocs_Gitlab_Exception extends Zend_Exception +{ + +} \ No newline at end of file diff --git a/application/modules/default/models/Project.php b/application/modules/default/models/Project.php index e07879d4e..d5f79185a 100644 --- a/application/modules/default/models/Project.php +++ b/application/modules/default/models/Project.php @@ -1,1882 +1,1884 @@ . **/ class Default_Model_Project extends Default_Model_DbTable_Project { const FILTER_NAME_PROJECT_ID_NOT_IN = 'project_id_not_in'; const FILTER_NAME_RANKING = 'ranking'; const FILTER_NAME_CATEGORY = 'category'; const FILTER_NAME_TAG = 'tag'; const FILTER_NAME_ORIGINAL = 'original'; const FILTER_NAME_MEMBER = 'member'; const FILTER_NAME_ORDER = 'order'; const FILTER_NAME_LOCATION = 'location'; const ITEM_TYPE_DUMMY = 0; const ITEM_TYPE_PRODUCT = 1; const ITEM_TYPE_UPDATE = 2; const TAG_LICENCE_GID = 7; const TAG_TYPE_ID = 1; /** * @param int $status * @param int $id * * @throws Exception */ public function setStatus($status, $id) { if (false === in_array($status, $this->_allowedStatusTypes)) { throw new Exception('Wrong value for project status.'); } $updateValues = array( 'status' => $status, 'changed_at' => new Zend_Db_Expr('Now()') ); if (self::PROJECT_DELETED == $status) { $updateValues['deleted_at'] = new Zend_Db_Expr('NOW()'); } $this->update($updateValues, $this->_db->quoteInto('project_id=?', $id, 'INTEGER')); } /** * @param int $member_id * @param int $id */ public function setClaimedByMember($member_id, $id) { $updateValues = array( 'claimed_by_member' => $member_id, 'changed_at' => new Zend_Db_Expr('Now()') ); $this->update($updateValues, $this->_db->quoteInto('project_id=?', $id, 'INTEGER')); } /** * @param int $id */ public function resetClaimedByMember($id) { $updateValues = array( 'claimed_by_member' => new Zend_Db_Expr('NULL'), 'changed_at' => new Zend_Db_Expr('Now()') ); $this->update($updateValues, $this->_db->quoteInto('project_id=?', $id, 'INTEGER')); } /** * @param int $id */ public function transferClaimToMember($id) { $project = $this->fetchProductInfo($id); //Update ppload $pploadFiles = new Default_Model_DbTable_PploadFiles(); $updateValues = array( 'owner_id' => $project->claimed_by_member ); $pploadFiles->update($updateValues, "collection_id = ".$project->ppload_collection_id); $pploadCollection = new Default_Model_DbTable_PploadCollections(); $updateValues = array( 'owner_id' => $project->claimed_by_member ); $pploadCollection->update($updateValues, "id = ".$project->ppload_collection_id); //And prohect $updateValues = array( 'member_id' => new Zend_Db_Expr('claimed_by_member'), 'claimable' => new Zend_Db_Expr('NULL'), 'claimed_by_member' => new Zend_Db_Expr('NULL') ); $this->update($updateValues, $this->_db->quoteInto('project_id=? and claimable = 1', $id, 'INTEGER')); } /** * @param int $project_id * @param $member_id * * @throws Zend_Db_Statement_Exception * @throws Zend_Exception */ public function setInActive($project_id, $member_id) { $project_id = (int)$project_id; $updateValues = array( 'status' => self::PROJECT_INACTIVE, 'deleted_at' => new Zend_Db_Expr('Now()') ); $this->update($updateValues, 'status > 40 AND project_id=' . $project_id); $this->setInActiveForUpdates($project_id); $this->setDeletedForComments($member_id,$project_id); } /** * @param int $id */ protected function setInActiveForUpdates($id) { $id = (int)$id; $updateValues = array( 'status' => self::PROJECT_INACTIVE, 'changed_at' => new Zend_Db_Expr('Now()') ); $this->update($updateValues, 'status > 40 AND pid=' . $id); } /** * @param int $member_id * @param int $id * * @throws Zend_Db_Statement_Exception * @throws Zend_Exception */ private function setDeletedForComments($member_id, $id) { $modelComments = new Default_Model_ProjectComments(); $modelComments->setAllCommentsForProjectDeleted($member_id, $id); } /** * @param int $id * * @return mixed * @throws Zend_Db_Statement_Exception */ public function fetchActiveBySourcePk($id) { $q = $this->select()->where('status = ?', self::PROJECT_ACTIVE)->where('source_pk = ?', (int)$id) ->where('source_type = "project"') ; return $q->query()->fetch(); } /** * @param int $member_id * @param bool $onlyActiveProjects * * @return mixed */ public function countAllProjectsForMember($member_id, $onlyActiveProjects = false) { $q = $this->select()->from($this, array('countAll' => new Zend_Db_Expr('count(*)')))->setIntegrityCheck(false) ->where('project.status >= ?', ($onlyActiveProjects ? self::PROJECT_ACTIVE : self::PROJECT_INACTIVE)) ->where('project.member_id = ?', $member_id, 'INTEGER')->where('project.type_id = ?', self::PROJECT_TYPE_STANDARD) ; $resultSet = $q->query()->fetchAll(); return $resultSet[0]['countAll']; } /** * @param int $member_id * @param bool $onlyActiveProjects * @param $catids * * @return mixed * @throws Zend_Cache_Exception * @throws Zend_Db_Statement_Exception */ public function countAllProjectsForMemberCatFilter($member_id, $onlyActiveProjects = false, $catids = null) { $q = $this->select()->from($this, array('countAll' => new Zend_Db_Expr('count(*)')))->setIntegrityCheck(false) ->where('project.status >= ?', ($onlyActiveProjects ? self::PROJECT_ACTIVE : self::PROJECT_INACTIVE)) ->where('project.member_id = ?', $member_id, 'INTEGER')->where('project.type_id = ?', self::PROJECT_TYPE_STANDARD) ; if (isset($catids)) { $q->where('project_category_id in (' . $this->_getCatIds($catids) . ')'); } $resultSet = $q->query()->fetchAll(); return $resultSet[0]['countAll']; } /** * @param $catids * * @return string * @throws Zend_Cache_Exception * @throws Zend_Db_Statement_Exception */ protected function _getCatIds($catids) { $sqlwhereCat = ""; $sqlwhereSubCat = ""; $idCategory = explode(',', $catids); if (false === is_array($idCategory)) { $idCategory = array($idCategory); } $sqlwhereCat .= implode(',', $idCategory); $modelCategory = new Default_Model_DbTable_ProjectCategory(); $subCategories = $modelCategory->fetchChildElements($idCategory); if (count($subCategories) > 0) { foreach ($subCategories as $element) { $sqlwhereSubCat .= "{$element['project_category_id']},"; } } return $sqlwhereSubCat . $sqlwhereCat; } /** * By default it will show all projects for a member included the unpublished elements. * * @param int $member_id * @param int|null $limit * @param int|null $offset * @param bool $onlyActiveProjects * * @return Zend_Db_Table_Rowset_Abstract */ public function fetchAllProjectsForMember($member_id, $limit = null, $offset = null, $onlyActiveProjects = false) { $q = $this->select()->from($this, array( '*', 'project_validated' => 'project.validated', 'project_uuid' => 'project.uuid', 'project_status' => 'project.status', 'project_created_at' => 'project.created_at', 'project_changed_at' => 'project.changed_at', 'member_type' => 'member.type', 'project_member_id' => 'member_id', 'laplace_score' => new Zend_Db_Expr('laplace_score(count_likes,count_dislikes)'), 'catTitle' => new Zend_Db_Expr('(SELECT title FROM project_category WHERE project_category_id = project.project_category_id)') ))->setIntegrityCheck(false)->join('member', 'project.member_id = member.member_id', array('username')) ->where('project.status >= ?', ($onlyActiveProjects ? self::PROJECT_ACTIVE : self::PROJECT_INACTIVE)) ->where('project.member_id = ?', $member_id, 'INTEGER')->where('project.type_id = ?', self::PROJECT_TYPE_STANDARD) ->order('project_changed_at DESC') ; if (isset($limit)) { $q->limit($limit, $offset); } return $this->generateRowSet($q->query()->fetchAll()); } /** * @param array $data * * @return Zend_Db_Table_Rowset_Abstract */ protected function generateRowSet($data) { $classRowSet = $this->getRowsetClass(); return new $classRowSet(array( 'table' => $this, 'rowClass' => $this->getRowClass(), 'stored' => true, 'data' => $data )); } /** * By default it will show all projects for a member included the unpublished elements. * * @param int $member_id * @param int|null $limit * @param int|null $offset * @param bool $onlyActiveProjects * * @param null $catids * * @return Zend_Db_Table_Rowset_Abstract * @throws Zend_Cache_Exception * @throws Zend_Db_Statement_Exception */ public function fetchAllProjectsForMemberCatFilter( $member_id, $limit = null, $offset = null, $onlyActiveProjects = false, $catids = null ) { $q = $this->select()->from($this, array( '*', 'project_validated' => 'project.validated', 'project_uuid' => 'project.uuid', 'project_status' => 'project.status', 'project_created_at' => 'project.created_at', 'project_changed_at' => 'project.changed_at', 'member_type' => 'member.type', 'project_member_id' => 'member_id', 'laplace_score' => new Zend_Db_Expr('laplace_score(count_likes,count_dislikes)'), 'catTitle' => new Zend_Db_Expr('(SELECT title FROM project_category WHERE project_category_id = project.project_category_id)') ))->setIntegrityCheck(false)->join('member', 'project.member_id = member.member_id', array('username')) ->where('project.status >= ?', ($onlyActiveProjects ? self::PROJECT_ACTIVE : self::PROJECT_INACTIVE)) ->where('project.member_id = ?', $member_id, 'INTEGER')->where('project.type_id = ?', self::PROJECT_TYPE_STANDARD) ->order('project_changed_at DESC') ; if (isset($catids)) { $q->where('project_category_id in (' . $this->_getCatIds($catids) . ')'); } if (isset($limit)) { $q->limit($limit, $offset); } return $this->generateRowSet($q->query()->fetchAll()); } /** * @param $collection_id * * @return null|Zend_Db_Table_Row_Abstract */ public function fetchProductForCollectionId($collection_id) { $sql = ' SELECT `p`.* FROM `project` AS `p` WHERE `p`.`ppload_collection_id` = :collectionId AND `p`.`status` >= :projectStatus AND `p`.`type_id` = :typeId '; $result = $this->_db->fetchRow($sql, array( 'collectionId' => $collection_id, 'projectStatus' => self::PROJECT_INACTIVE, 'typeId' => self::PROJECT_TYPE_STANDARD )); if ($result) { return $this->generateRowClass($result); } else { return null; } } /** * @param int $project_id * * @return null|Zend_Db_Table_Row_Abstract */ public function fetchProductInfo($project_id) { $sql = ' SELECT `p`.*, `p`.`validated` AS `project_validated`, `p`.`uuid` AS `project_uuid`, `p`.`status` AS `project_status`, `p`.`created_at` AS `project_created_at`, `p`.`major_updated_at` AS `project_major_updated_at`, `p`.`changed_at` AS `project_changed_at`, `p`.`member_id` AS `project_member_id`, `p`.`source_pk` AS `project_source_pk`, `p`.`version` AS `project_version`, `pc`.`title` AS `cat_title`, `m`.`username`, `m`.`avatar`, `m`.`profile_image_url`, `m`.`roleId`, `m`.`mail`, `m`.`paypal_mail`, `m`.`dwolla_id`, IFNULL(pr.score_with_pling, 500) AS laplace_score, `view_reported_projects`.`amount_reports` AS `amount_reports`, (SELECT `tag`.`tag_fullname` FROM `tag_object`, `tag` WHERE `tag_object`.`tag_id`=`tag`.`tag_id` AND `tag_object_id` = `p`.`project_id` AND `tag_object`.`is_deleted`=0 AND `tag_group_id` = :tag_licence_gid AND `tag_type_id` = :tag_type_id ORDER BY `tag_object`.`tag_created` DESC LIMIT 1) AS `project_license_title` FROM `project` AS `p` JOIN `member` AS `m` ON `p`.`member_id` = `m`.`member_id` AND `m`.`is_active` = 1 AND `m`.`is_deleted` = 0 JOIN `project_category` AS `pc` ON `p`.`project_category_id` = `pc`.`project_category_id` LEFT join stat_rating_project AS pr ON p.project_id = pr.project_id LEFT JOIN `view_reported_projects` ON ((`view_reported_projects`.`project_id` = `p`.`project_id`)) WHERE `p`.`project_id` = :projectId AND `p`.`status` >= :projectStatus AND (`p`.`type_id` = :typeIdStd OR `p`.`type_id` = :typeIdColl) '; $result = $this->_db->fetchRow($sql, array( 'projectId' => $project_id, 'projectStatus' => self::PROJECT_INACTIVE, 'typeIdStd' => self::PROJECT_TYPE_STANDARD, 'typeIdColl' => self::PROJECT_TYPE_COLLECTION, 'tag_licence_gid' => self::TAG_LICENCE_GID, 'tag_type_id' => self::TAG_TYPE_ID )); if ($result) { return $this->generateRowClass($result); } else { return null; } } /** * @param int $project_id * * @return null|Zend_Db_Table_Row_Abstract */ public function fetchProductInfo_($project_id) { $sql = ' SELECT `p`.*, `p`.`validated` AS `project_validated`, `p`.`uuid` AS `project_uuid`, `p`.`status` AS `project_status`, `p`.`created_at` AS `project_created_at`, `p`.`changed_at` AS `project_changed_at`, `p`.`member_id` AS `project_member_id`, `p`.`source_pk` AS `project_source_pk`, `p`.`version` AS `project_version`, `pc`.`title` AS `cat_title`, `m`.`username`, `m`.`avatar`, `m`.`profile_image_url`, `m`.`roleId`, `m`.`mail`, `m`.`paypal_mail`, `m`.`dwolla_id`, IFNULL(pr.score_with_pling, 500) AS laplace_score, `view_reported_projects`.`amount_reports` AS `amount_reports`, `project_license`.`title` AS `project_license_title` FROM `project` AS `p` JOIN `member` AS `m` ON `p`.`member_id` = `m`.`member_id` AND `m`.`is_active` = 1 AND `m`.`is_deleted` = 0 JOIN `project_category` AS `pc` ON `p`.`project_category_id` = `pc`.`project_category_id` LEFT join stat_rating_project AS pr ON p.project_id = pr.project_id LEFT JOIN `view_reported_projects` ON ((`view_reported_projects`.`project_id` = `p`.`project_id`)) LEFT JOIN `project_license` ON ((`project_license`.`project_license_id` = `p`.`project_license_id`)) WHERE `p`.`project_id` = :projectId AND `p`.`status` >= :projectStatus AND `p`.`type_id` = :typeId '; $result = $this->_db->fetchRow($sql, array( 'projectId' => $project_id, 'projectStatus' => self::PROJECT_INACTIVE, 'typeId' => self::PROJECT_TYPE_STANDARD )); if ($result) { return $this->generateRowClass($result); } else { return null; } } /** * @param $project_id * * @return Zend_Db_Table_Rowset_Abstract */ public function fetchProjectUpdates($project_id) { $projectSel = $this->select()->setIntegrityCheck(false)->from($this->_name) ->join('member', 'project.member_id = member.member_id', array('*')) ->where('project.pid=?', $project_id, 'INTEGER')->where('project.status>?', self::PROJECT_INACTIVE) ->where('project.type_id=?', self::PROJECT_TYPE_UPDATE)->order('RAND()') ; return $this->fetchAll($projectSel); } /** * @param $project_id * * @return Zend_Db_Table_Rowset_Abstract */ public function fetchAllProjectUpdates($project_id) { $projectSel = $this->select()->setIntegrityCheck(false)->from($this->_name)->where('project.pid=?', $project_id, 'INTEGER') ->where('project.status>?', self::PROJECT_INACTIVE)->where('project.type_id=?', self::PROJECT_TYPE_UPDATE) ; return $this->fetchAll($projectSel); } /** * @param $project * @param int $count * * @return Zend_Db_Table_Rowset_Abstract */ public function fetchSimilarProjects($project, $count = 10) { $count = (int)$count; $sql = " SELECT * FROM `stat_projects` AS `p` WHERE `p`.`project_category_id` = :cat_id AND `project_id` <> :project_id ORDER BY `p`.`changed_at` DESC LIMIT {$count} "; $result = $this->_db->fetchAll($sql, array( 'cat_id' => $project->project_category_id, 'project_id' => $project->project_id )); return $this->generateRowSet($result); } /** * @param Zend_Db_Table_Row $project * @param int $count * * @return Zend_Db_Table_Rowset_Abstract * @throws Zend_Exception */ public function fetchMoreProjects($project, $count = 6) { $q = $this->select()->from(array('project' => 'stat_projects'), array( 'project_id', 'image_small', 'title', 'catTitle' => 'cat_title', 'changed_at' ))->setIntegrityCheck(false) ->where('project.status = ?', self::PROJECT_ACTIVE) ->where('project.member_id = ?', $project->member_id, 'INTEGER') ->where('project.project_id != ?', $project->project_id, 'INTEGER') ->where('project.type_id = ?', self::PROJECT_TYPE_STANDARD) ->where('project.amount_reports is null') ->where('project.project_category_id = ?', $project->project_category_id, 'INTEGER') ->limit($count) ->order('project.project_created_at DESC') ; $tagFilter = Zend_Registry::isRegistered('config_store_tags') ? Zend_Registry::get('config_store_tags') : null; if ($tagFilter) { $q = $this->generateTagFilter($q, array(self::FILTER_NAME_TAG => $tagFilter)); } $result = $this->fetchAll($q); return $result; } /** * @param Zend_Db_Select $statement * @param array $filterArrayValue * * @return Zend_Db_Select */ protected function generateTagFilter(Zend_Db_Select $statement, $filterArrayValue) { if (false == isset($filterArrayValue[self::FILTER_NAME_TAG])) { return $statement; } $filter = $filterArrayValue[self::FILTER_NAME_TAG]; if (is_array($filter)) { $tagList = $filter; //build where statement für projects $selectAnd = $this->select()->from(array('project' => 'stat_projects')); foreach($tagList as $item) { #and $selectAnd->where('find_in_set(?, tag_ids)', $item); } $statement->where(implode(' ', $selectAnd->getPart('where'))); /* $statement->join(array( 'tags' => new Zend_Db_Expr('(SELECT DISTINCT project_id FROM stat_project_tagids WHERE tag_id in (' . implode(',', $filter) . '))') ), 'project.project_id = tags.project_id', array()); * */ } else { $statement->where('find_in_set(?, tag_ids)', $filter); } return $statement; } /** * @param $project * @param int $count * * @return Zend_Db_Table_Rowset_Abstract * @throws Zend_Db_Statement_Exception * @throws Zend_Exception * @todo improve processing speed */ public function fetchMoreProjectsOfOtherUsr($project, $count = 8) { $sql = " SELECT count(1) AS `count` FROM `stat_projects` WHERE `status` = :current_status AND `member_id` <> :current_member_id AND `project_category_id` = :category_id AND `type_id` = :project_type "; $result = $this->_db->query($sql, array( 'current_status' => self::PROJECT_ACTIVE, 'current_member_id' => $project->member_id, 'category_id' => $project->project_category_id, 'project_type' => self::PROJECT_TYPE_STANDARD ))->fetch() ; if ($result['count'] > $count) { $offset = rand(0, $result['count'] - $count); } else { $offset = 0; } $q = $this->select()->from(array('project' => 'stat_projects'), array( 'project_id', 'image_small', 'title', 'catTitle' => 'cat_title', 'changed_at' ))->setIntegrityCheck(false)->where('status = ?', self::PROJECT_ACTIVE) ->where('member_id != ?', $project->member_id, 'INTEGER')->where('type_id = ?', 1) ->where('amount_reports is null') ->where('project_category_id = ?', $project->project_category_id, 'INTEGER')->limit($count, $offset) ->order('project_created_at DESC') ; $tagFilter = Zend_Registry::isRegistered('config_store_tags') ? Zend_Registry::get('config_store_tags') : null; if ($tagFilter) { $q = $this->generateTagFilter($q, array(self::FILTER_NAME_TAG => $tagFilter)); } $result = $this->fetchAll($q); return $result; } /** * @param int $project_id * * @return Zend_Db_Table_Rowset_Abstract */ public function fetchProjectSupporter($project_id) { $plingTable = new Default_Model_DbTable_Plings(); return $plingTable->getSupporterForProjectId($project_id); } /** * @param int $project_id * * @return Zend_Db_Table_Rowset_Abstract */ public function fetchProjectSupporterWithPlings($project_id) { $plingTable = new Default_Model_DbTable_Plings(); return $plingTable->getSupporterWithPlingsForProjectId($project_id); } /** * @param $projectId * @param $sources */ public function updateGalleryPictures($projectId, $sources) { $galleryPictureTable = new Default_Model_DbTable_ProjectGalleryPicture(); $galleryPictureTable->clean($projectId); $galleryPictureTable->insertAll($projectId, $sources); } /** * @param $projectId * * @return array */ public function getGalleryPictureSources($projectId) { $galleryPictureTable = new Default_Model_DbTable_ProjectGalleryPicture(); $stmt = $galleryPictureTable->select()->where('project_id = ?', $projectId)->order(array('sequence')); $pics = array(); foreach ($galleryPictureTable->fetchAll($stmt) as $pictureRow) { $pics[] = $pictureRow['picture_src']; } return $pics; } /** * @param int $project_id * * @return array * @throws Zend_Db_Statement_Exception */ public function fetchProjectViews($project_id) { $sql = " SELECT `project_id`, `count_views`, `count_visitor`, `last_view` FROM `stat_page_views_mv` WHERE `project_id` = ? "; $database = Zend_Db_Table::getDefaultAdapter(); $sql = $database->quoteInto($sql, $project_id, 'INTEGER', 1); $resultSet = $database->query($sql)->fetchAll(); if (count($resultSet) > 0) { $result = $resultSet[0]['count_views']; } else { $result = 0; } return $result; } /** * @param int $member_id * * @return int * @throws Zend_Db_Statement_Exception */ public function fetchOverallPageViewsByMember($member_id) { $sql = " SELECT sum(`stat`.`amount`) AS `page_views` FROM `project` JOIN (SELECT `project_id`, count(`project_id`) AS `amount` FROM `stat_page_views` GROUP BY `project_id`) AS `stat` ON `stat`.`project_id` = `project`.`project_id` WHERE `project`.`member_id` = :member_id AND `project`.`status` = :project_status GROUP BY `member_id` "; $result = $this->_db->query($sql, array('member_id' => $member_id, 'project_status' => self::PROJECT_ACTIVE)); if ($result->rowCount() > 0) { $row = $result->fetch(); return $row['page_views']; } else { return 0; } } /** * @return array * @throws Zend_Db_Statement_Exception */ public function getStatsForNewProjects() { $sql = " SELECT DATE_FORMAT(`time`, '%M %D') AS `projectdate`, count(1) AS `daycount` FROM `activity_log` WHERE `activity_type_id` = 0 GROUP BY DATE_FORMAT(`time`, '%Y%M%D') ORDER BY `time` DESC LIMIT 14 ;"; $database = Zend_Db_Table::getDefaultAdapter(); $resultSet = $database->query($sql)->fetchAll(); return $resultSet; } /** * @param int $idCategory * @param int|null $limit * * @return Zend_Db_Table_Rowset_Abstract * @throws Zend_Cache_Exception * @throws Zend_Db_Statement_Exception */ public function fetchProductsByCategory($idCategory, $limit = null) { $select = $this->select()->setIntegrityCheck(false)->from($this->_name)->where('project.project_category_id in (?)', $idCategory) ->where('project.status = ?', self::PROJECT_ACTIVE)->where('project.type_id = ?', self::PROJECT_TYPE_STANDARD) ->joinLeft(array( 'pling_amount' => new Zend_Db_Expr('(SELECT project_id as plinged_project_id, SUM(amount) AS sumAmount, count(1) as countPlings FROM plings where status_id >= 2 group by project_id order by sumAmount DESC)') ), 'pling_amount.plinged_project_id = project.project_id') ->joinLeft('project_category', 'project_category.project_category_id = project.project_category_id', array('cat_title' => 'title'))->order('pling_amount.sumAmount DESC') ; if (false === is_null($limit)) { $select->limit($limit); } $modelCategory = new Default_Model_DbTable_ProjectCategory(); $subCategories = $modelCategory->fetchChildElements($idCategory); if (count($subCategories) > 0) { $sqlwhere = ''; foreach ($subCategories as $element) { $sqlwhere .= "{$element['project_category_id']},"; } $sqlwhere = substr($sqlwhere, 0, -1); if (!empty($sqlwhere)) { $sqlwhere = explode(',', $sqlwhere); } $select->orWhere('project.project_category_id in (?)', $sqlwhere); } return $this->fetchAll($select); } /** * @param int|array $idCategory id of a category or an array of id's * @param bool $withSubCat if was set true it will also count products in sub categories * @param null $store_id * * @return int count of products in given category * @throws Zend_Exception * @deprecated */ public function countProductsInCategory($idCategory = null, $withSubCat = true, $store_id = null) { if (empty($idCategory)) { throw new Zend_Exception('idCategory param was not set'); } if (false == is_array($idCategory)) { $idCategory = array($idCategory); } if (isset($store_id)) { $configurations = Zend_Registry::get('application_store_config_id_list'); $store_config = isset($configurations[$store_id]) ? $configurations[$store_id] : null; } else { $store_config = Zend_Registry::isRegistered('store_config') ? Zend_Registry::get('store_config') : null; } $tagFilter = Zend_Registry::isRegistered('config_store_tags') ? Zend_Registry::get('config_store_tags') : null; $cacheName = __FUNCTION__ . '_' . md5(serialize($idCategory) . $withSubCat . serialize($tagFilter)); /** @var Zend_Cache_Core $cache */ $cache = Zend_Registry::get('cache'); if (false !== ($resultSet = $cache->load($cacheName))) { return (int)$resultSet[0]['count_active_projects']; } $select = $this->select()->setIntegrityCheck(false)->from('stat_projects', array('count_active_projects' => 'COUNT(1)')) ->where('status = ? ', self::PROJECT_ACTIVE)->where('type_id = ?', self::PROJECT_TYPE_STANDARD) ; $select = $this->generateTagFilter($select, array(self::FILTER_NAME_TAG => $tagFilter)); if ($withSubCat) { $modelCategory = new Default_Model_DbTable_ProjectCategory(); $subCategories = $modelCategory->fetchChildIds($idCategory); $inCategories = implode(',', array_unique(array_merge($idCategory, $subCategories))); } else { $inCategories = implode(',', $idCategory); } $select->where('project_category_id in (' . $inCategories . ')'); $resultSet = $this->fetchAll($select)->toArray(); $cache->save($resultSet, $cacheName, array(), 60); return (int)$resultSet[0]['count_active_projects']; } /** * @param int|array $idCategory * * @return int * @throws Zend_Exception */ public function countActiveMembersForCategory($idCategory) { $cacheName = __FUNCTION__ . md5(serialize($idCategory)); $cache = Zend_Registry::get('cache'); $result = $cache->load($cacheName); if ($result) { return (int)$result['count_active_members']; } $sqlwhereCat = ""; $sqlwhereSubCat = ""; if (false === is_array($idCategory)) { $idCategory = array($idCategory); } $sqlwhereCat .= implode(',', $idCategory); $modelCategory = new Default_Model_DbTable_ProjectCategory(); $subCategories = $modelCategory->fetchChildElements($idCategory); if (count($subCategories) > 0) { foreach ($subCategories as $element) { $sqlwhereSubCat .= "{$element['project_category_id']},"; } } $selectWhere = 'AND p.project_category_id in (' . $sqlwhereSubCat . $sqlwhereCat . ')'; $sql = "SELECT count(1) AS `count_active_members` FROM ( SELECT count(1) AS `count_active_projects` FROM `project` `p` WHERE `p`.`status` = 100 AND `p`.`type_id` = 1 {$selectWhere} GROUP BY p.member_id ) AS `A`;"; $result = $this->_db->fetchRow($sql); $cache->save($result, $cacheName); return (int)$result['count_active_members']; } /** * @param int $project_id * * @return bool */ public function isProjectFeatured($project_id) { $sql_object = "SELECT `project_id` FROM `project` WHERE `project_id`= :project_id AND `status` = 100 AND `type_id` = 1 AND `featured` = 1"; $r = $this->getAdapter()->fetchRow($sql_object, array('project_id' => $project_id)); if ($r) { return true; } else { return false; } } /** * @param bool $in_current_store * * @return int * @throws Zend_Exception */ public function fetchTotalProjectsCount($in_current_store = false) { $sql = "SELECT count(1) AS `total_project_count` FROM `stat_projects`"; if ($in_current_store) { $store_tags = Zend_Registry::isRegistered('config_store_tags') ? Zend_Registry::get('config_store_tags') : null; /* if ($store_tags) { $sql .= ' JOIN (SELECT DISTINCT project_id FROM stat_project_tagids WHERE tag_id in (' . implode(',', $store_tags) . ')) AS tags ON stat_projects.project_id = tags.project_id'; } * */ $info = new Default_Model_Info(); $activeCategories = $info->getActiveCategoriesForCurrentHost(); $sql .= ' WHERE project_category_id IN (' . implode(',', $activeCategories) . ')'; //Store Tag Filter if ($store_tags) { $tagList = $store_tags; //build where statement für projects $sql .= " AND ("; if(!is_array($tagList)) { $tagList = array($tagList); } foreach($tagList as $item) { #and $sql .= ' find_in_set('.$item.', tag_ids) AND '; } $sql .= ' 1=1)';; } } $result = $this->_db->fetchRow($sql); return (int)$result['total_project_count']; } /** * @param $member_id * * @throws Zend_Db_Statement_Exception * @throws Zend_Exception */ public function setAllProjectsForMemberDeleted($member_id) { $sql = "SELECT `project_id` FROM `project` WHERE `member_id` = :memberId AND `type_id` = :typeId AND `status` > :project_status"; $projectForDelete = $this->_db->fetchAll($sql, array( 'memberId' => $member_id, 'typeId' => self::PROJECT_TYPE_STANDARD, 'project_status' => self::PROJECT_DELETED )); foreach ($projectForDelete as $item) { $this->setDeleted($member_id, $item['project_id']); } // set personal page deleted $sql = "SELECT project_id FROM project WHERE member_id = :memberId AND type_id = :typeId"; $projectForDelete = $this->_db->fetchAll($sql, array( 'memberId' => $member_id, 'typeId' => self::PROJECT_TYPE_PERSONAL )); foreach ($projectForDelete as $item) { $this->setDeleted($member_id, $item['project_id']); } /* $sql = "UPDATE project SET `status` = :statusCode, deleted_at = NOW() WHERE member_id = :memberId AND type_id = :typeId"; $this->_db->query($sql, array( 'statusCode' => self::PROJECT_DELETED, 'memberId' => $member_id, 'typeId' => self::PROJECT_TYPE_PERSONAL ))->execute(); */ } /** * @param int $member_id * @param int $id * * @throws Zend_Db_Statement_Exception * @throws Zend_Exception */ public function setDeleted($member_id, $id) { $id = (int)$id; $updateValues = array( 'status' => self::PROJECT_DELETED, 'deleted_at' => new Zend_Db_Expr('Now()') ); $this->update($updateValues, 'status > 30 AND project_id=' . $id); $memberLog = new Default_Model_MemberDeactivationLog(); $memberLog->logProjectAsDeleted($member_id, $id); $this->setDeletedForUpdates($member_id, $id); $this->setDeletedForComments($member_id, $id); $this->setDeletedInMaterializedView($id); } /** * @param $member_id * @param int $id */ protected function setDeletedForUpdates($member_id, $id) { $id = (int)$id; $updateValues = array( 'status' => self::PROJECT_DELETED, 'deleted_at' => new Zend_Db_Expr('Now()') ); $this->update($updateValues, 'status > 30 AND pid=' . $id); } /** * @param $id * * @throws Zend_Db_Statement_Exception */ private function setDeletedInMaterializedView($id) { $sql = "UPDATE `stat_projects` SET `status` = :new_status WHERE `project_id` = :project_id"; $result = $this->_db->query($sql, array('new_status' => self::PROJECT_DELETED, 'project_id' => $id))->execute(); } /** * @param int $member_id * * @throws Zend_Exception */ public function setAllProjectsForMemberActivated($member_id) { $sql = "SELECT `p`.`project_id` FROM `project` `p` JOIN `member_deactivation_log` `l` ON `l`.`object_type_id` = 3 AND `l`.`object_id` = `p`.`project_id` AND `l`.`deactivation_id` = `p`.`member_id` WHERE `p`.`member_id` = :memberId"; $projectForDelete = $this->_db->fetchAll($sql, array( 'memberId' => $member_id )); foreach ($projectForDelete as $item) { $this->setActive($member_id, $item['project_id']); } } /** * @param int $member_id * @param int $id * * @throws Zend_Exception */ public function setActive($member_id, $id) { $updateValues = array( 'status' => self::PROJECT_ACTIVE, 'deleted_at' => null ); $this->update($updateValues, $this->_db->quoteInto('project_id=?', $id, 'INTEGER')); $memberLog = new Default_Model_MemberDeactivationLog(); $memberLog->removeLogProjectAsDeleted($member_id, $id); $this->setActiveForUpdates($member_id, $id); $this->setActiveForComments($member_id, $id); } /** * @param int $id */ protected function setActiveForUpdates($member_id, $id) { $updateValues = array( 'status' => self::PROJECT_ACTIVE, 'deleted_at' => null ); $this->update($updateValues, $this->_db->quoteInto('pid=?', $id, 'INTEGER')); } /** * @param int $member_id * @param int $project_id */ private function setActiveForComments($member_id, $project_id) { $modelComments = new Default_Model_ProjectComments(); $modelComments->setAllCommentsForProjectActivated($member_id, $project_id); } /** * @param array $inputFilterParams * @param int|null $limit * @param int|null $offset * * @return array * @throws Zend_Cache_Exception * @throws Zend_Db_Select_Exception * @throws Zend_Exception */ public function fetchProjectsByFilter($inputFilterParams, $limit = null, $offset = null) { $cacheName = __FUNCTION__ . '_' . md5(serialize($inputFilterParams) . (string)$limit . (string)$offset); /** @var Zend_Cache_Core $cache */ $cache = Zend_Registry::get('cache'); if (false === ($returnValue = $cache->load($cacheName))) { $statement = $this->generateStatement($inputFilterParams, $limit, $offset); if (APPLICATION_ENV == 'development') { Zend_Registry::get('logger')->debug(__METHOD__ . ' - ' . $statement->__toString()); } /** @var Zend_Db_Table_Rowset $fetchedElements */ $fetchedElements = $this->fetchAll($statement); $statement->reset('limitcount')->reset('limitoffset'); $statement->reset('columns')->columns(array('count' => new Zend_Db_Expr('count(*)'))); $countElements = $this->fetchRow($statement); $returnValue = array('elements' => $fetchedElements, 'total_count' => $countElements->count); $cache->save($returnValue, $cacheName, array(), 120); } return $returnValue; } /** * @param array $inputFilterParams * @param int|null $limit * @param int|null $offset * * @return Zend_Db_Select * @throws Zend_Cache_Exception * @throws Zend_Db_Statement_Exception */ protected function generateStatement($inputFilterParams, $limit = null, $offset = null) { $statement = $this->generateBaseStatement(); $statement = $this->generateCategoryFilter($statement, $inputFilterParams); $statement = $this->generateOrderFilter($statement, $inputFilterParams); $statement = $this->generateTagFilter($statement, $inputFilterParams); $statement = $this->generateOriginalFilter($statement, $inputFilterParams); $statement = $this->generateReportedSpamFilter($statement); $statement->limit($limit, $offset); return $statement; } /** * @return Zend_Db_Select */ protected function generateBaseStatement() { $statement = $this->select()->setIntegrityCheck(false); //$statement->from(array('project' => $this->_name), array( $statement->from(array('project' => 'stat_projects'), array( '*' )); $statement->where('project.status = ?', self::PROJECT_ACTIVE)->where('project.type_id IN (?)', array(self::PROJECT_TYPE_STANDARD, self::PROJECT_TYPE_COLLECTION)); return $statement; } /** * @param Zend_Db_Select $statement * @param array $filterArrayValue * * @return Zend_Db_Select * @throws Zend_Cache_Exception * @throws Zend_Db_Statement_Exception */ protected function generateCategoryFilter(Zend_Db_Select $statement, $filterArrayValue) { if (false == isset($filterArrayValue[self::FILTER_NAME_CATEGORY])) { return $statement; } $filter = $filterArrayValue[self::FILTER_NAME_CATEGORY]; if (false === is_array($filter)) { $filter = array($filter); } // fetch child elements for each category $modelProjectCategories = new Default_Model_DbTable_ProjectCategory(); $childElements = $modelProjectCategories->fetchChildIds($filter); $allCategories = array_unique(array_merge($filter, $childElements)); $stringCategories = implode(',', $allCategories); $statement->where("( project.project_category_id IN ({$stringCategories}) )"); return $statement; } /** * @param Zend_Db_Select $statement * @param array $filterArrayValue * * @return Zend_Db_Select */ protected function generateOrderFilter(Zend_Db_Select $statement, $filterArrayValue) { if (!isset($filterArrayValue[self::FILTER_NAME_ORDER])) { $filterValue = ''; } else { $filterValue = $filterArrayValue[self::FILTER_NAME_ORDER]; } switch ($filterValue) { case 'latest': $statement->order('project.major_updated_at DESC'); //$statement->order('project.changed_at DESC'); break; case 'rating': //$statement->order(array('amount_received DESC', 'count_plings DESC', 'latest_pling DESC', 'project.created_at DESC')); //$statement->order(array(new Zend_Db_Expr('(round(((count_likes + 6) / ((count_likes + count_dislikes) + 12)),2) * 100) DESC'),'amount_received DESC', 'count_plings DESC', 'latest_pling DESC', 'project.created_at DESC')); /*$statement->order(array( new Zend_Db_Expr('(round(((count_likes + 6) / ((count_likes + count_dislikes) + 12)),2) * 100) DESC'), 'project.created_at DESC' ));*/ $statement->order('project.laplace_score DESC'); break; case 'top': $statement->order('project.laplace_score_old DESC'); break; case 'download': $statement->order('project.count_downloads_hive DESC'); break; case 'downloadQuarter': $statement->order('project.count_downloads_quarter DESC'); break; case 'hot': //$statement->order(array('amount_received DESC', 'count_plings DESC', 'latest_pling DESC', 'project.created_at DESC')); $statement->order(array( new Zend_Db_Expr('(round(((count_likes + 6) / ((count_likes + count_dislikes) + 12)),2) * 100) DESC'), 'amount_received DESC', 'count_plings DESC', 'latest_pling DESC', 'project.created_at DESC' )); $statement->where(' project.created_at >= (NOW()- INTERVAL 14 DAY)'); break; case 'alpha': default: $statement->order('project.title'); } return $statement; } /** * @param Zend_Db_Select $statement * @param array $filterArrayValue * * @return Zend_Db_Select */ protected function generateOriginalFilter(Zend_Db_Select $statement, $filterArrayValue) { if (false == isset($filterArrayValue[self::FILTER_NAME_ORIGINAL])) { return $statement; } $filter = $filterArrayValue[self::FILTER_NAME_ORIGINAL]; if (is_array($filter)) { // todo maybe for other tags filter } else { $statement->where('find_in_set(?, tags)', $filter); } return $statement; } /** * @param Zend_Db_Select $statement * * @return Zend_Db_Select */ protected function generateReportedSpamFilter(Zend_Db_Select $statement) { return $statement->where('(amount_reports is null)'); } /** * @param int $member_id * @param array $values * @param string $username * * @return Zend_Db_Table_Row_Abstract * @throws Exception * @throws Zend_Db_Table_Exception */ public function createProject($member_id, $values, $username) { $values = (array)$values; if (empty($member_id)) { throw new Zend_Db_Table_Exception('member_id is not set'); } if (empty($username)) { throw new Zend_Db_Table_Exception('username is not set'); } // check important values for a new project $values['uuid'] = (!array_key_exists('uuid', $values)) ? Local_Tools_UUID::generateUUID() : $values['uuid']; $values['member_id'] = (!array_key_exists('member_id', $values)) ? $member_id : $values['member_id']; $values['status'] = (!array_key_exists('status', $values)) ? self::PROJECT_INACTIVE : $values['status']; $values['type_id'] = (!array_key_exists('type_id', $values)) ? self::ITEM_TYPE_PRODUCT : $values['type_id']; $values['created_at'] = (!array_key_exists('created_at', $values)) ? new Zend_Db_Expr('NOW()') : $values['created_at']; $values['start_date'] = (!array_key_exists('start_date', $values)) ? new Zend_Db_Expr('NULL') : $values['start_date']; $values['creator_id'] = (!array_key_exists('creator_id', $values)) ? $member_id : $values['creator_id']; + $values['gitlab_project_id'] = empty($values['gitlab_project_id']) ? new Zend_Db_Expr('NULL') : $values['gitlab_project_id']; if ($username == 'pling editor') { $values['claimable'] = (!array_key_exists('claimable', $values)) ? self::PROJECT_CLAIMABLE : $values['claimable']; } $savedRow = $this->save($values); return $savedRow; } /** * @param int $project_id * @param array $values * * @return Zend_Db_Table_Row_Abstract - * @throws Exception * @throws Zend_Db_Table_Exception */ public function updateProject($project_id, $values) { $values = (array)$values; $projectData = $this->find($project_id)->current(); if (empty($projectData)) { throw new Zend_Db_Table_Exception('project_id not found'); } + $values['gitlab_project_id'] = empty($values['gitlab_project_id']) ? new Zend_Db_Expr('NULL') : $values['gitlab_project_id']; + $projectData->setFromArray($values)->save(); return $projectData; } /** * @param int $member_id * * @return array|mixed */ public function fetchMainProject($member_id) { $sql = "SELECT * FROM {$this->_name} WHERE type_id = :type AND member_id = :member"; // $this->_db->getProfiler()->setEnabled(true); $result = $this->_db->fetchRow($sql, array('type' => self::PROJECT_TYPE_PERSONAL, 'member' => (int)$member_id)); // $dummy = $this->_db->getProfiler()->getLastQueryProfile()->getQuery(); // $this->_db->getProfiler()->setEnabled(true); if (count($result) > 0) { return $result; } else { return array(); } } /** * @param $project_id * * @return Zend_Db_Table_Row_Abstract * @throws Zend_Db_Statement_Exception */ public function fetchProductDataFromMV($project_id) { $sql = "SELECT * FROM `stat_projects` WHERE `project_id` = :project_id"; $resultSet = $this->_db->query($sql, array('project_id' => $project_id))->fetch(); if (false === $resultSet) { return $this->generateRowClass(array()); } return $this->generateRowClass($resultSet); } /** * @return array */ public function fetchGhnsExcludedProjects() { $sql = " SELECT `p`.`project_id`, `p`.`title`, `l`.`member_id` AS `exclude_member_id`, `l`.`time` AS `exclude_time`, `m`.`username` AS `exclude_member_name` FROM `project` `p` JOIN `activity_log` `l` ON `l`.`project_id` = `p`.`project_id` AND `l`.`activity_type_id` = 314 INNER JOIN `member` `m` ON `m`.`member_id` = `l`.`member_id` WHERE `p`.`ghns_excluded` = 1 "; $list = $this->_db->fetchAll($sql); return $list; } public function getUserCreatingCategorys($member_id) { $sql = " select c.title as category1, count(1) as cnt from project p join project_category c on p.project_category_id = c.project_category_id where p.status = 100 and p.member_id =:member_id and p.type_id = 1 group by c.title order by cnt desc, c.title asc "; $result = $this->_db->fetchAll($sql, array('member_id' => $member_id)); return $result; } /** * @return array */ public function getUserActiveProjects($member_id, $limit = null, $offset = null) { // for member me page $sql = " SELECT `p`.`project_id`, `p`.`title`, `p`.`created_at` AS `project_created_at`, `p`.`changed_at` AS `project_changed_at`, `pr`.`likes` AS count_likes, `pr`.`dislikes`AS count_dislikes, IFNULL(pr.score_with_pling, 500) AS laplace_score, `p`.`member_id`, `cat`.`title` AS `catTitle`, `p`.`project_category_id`, `p`.`image_small`, (SELECT count(1) FROM `project_plings` `l` WHERE `p`.`project_id` = `l`.`project_id` AND `l`.`is_deleted` = 0 AND `l`.`is_active` = 1 ) `countplings`, c.cnt cntCategory FROM `project` `p` join project_category cat on p.project_category_id = cat.project_category_id LEFT join stat_rating_project AS pr ON p.project_id = pr.project_id left join stat_cnt_projects_catid_memberid c on p.project_category_id = c.project_category_id and p.member_id = c.member_id WHERE `p`.`status` =100 and `p`.`type_id` = 1 AND `p`.`member_id` = :member_id ORDER BY cntCategory desc,catTitle asc, `p`.`changed_at` DESC "; if (isset($limit)) { $sql = $sql . ' limit ' . $limit; } if (isset($offset)) { $sql = $sql . ' offset ' . $offset; } $result = $this->_db->fetchAll($sql, array('member_id' => $member_id)); if ($result) { return $this->generateRowClass($result); } else { return null; } } /** * @return array */ public function getUserActiveProjectsDuplicatedSourceurl($member_id, $limit = null, $offset = null) { // for member me page $sql = " select * from ( SELECT `p`.`project_id`, `p`.`title`, `p`.`created_at` AS `project_created_at`, `p`.`changed_at` AS `project_changed_at`, `pr`.`likes` AS count_likes, `pr`.`dislikes`AS count_dislikes, IFNULL(pr.score_with_pling, 500) AS laplace_score, `p`.`member_id`, `cat`.`title` AS `catTitle`, `p`.`project_category_id`, `p`.`image_small`, (SELECT count(1) FROM `project_plings` `l` WHERE `p`.`project_id` = `l`.`project_id` AND `l`.`is_deleted` = 0 AND `l`.`is_active` = 1 ) `countplings`, c.cnt cntCategory, (select count(1) from stat_projects_source_url s where TRIM(TRAILING '/' FROM p.source_url) = s.source_url) as cntDuplicates FROM `project` `p` join project_category cat on p.project_category_id = cat.project_category_id left join stat_cnt_projects_catid_memberid c on p.project_category_id = c.project_category_id and p.member_id = c.member_id LEFT join stat_rating_project AS pr ON p.project_id = pr.project_id WHERE `p`.`status` =100 and `p`.`type_id` = 1 AND `p`.`member_id` = :member_id ORDER BY cntCategory desc,catTitle asc, `p`.`changed_at` DESC ) t where t.cntDuplicates >1 "; if (isset($limit)) { $sql = $sql . ' limit ' . $limit; } if (isset($offset)) { $sql = $sql . ' offset ' . $offset; } $result = $this->_db->fetchAll($sql, array('member_id' => $member_id)); if ($result) { return $this->generateRowClass($result); } else { return null; } } /** * @param int $member_id * @param int|null $limit * @param int|null $offset * * @return null|Zend_Db_Table_Row_Abstract */ public function fetchAllFeaturedProjectsForMember($member_id, $limit = null, $offset = null) { // for member me page $sql = " SELECT `p`.`project_id`, `p`.`title`, `p`.`created_at` AS `project_created_at`, `p`.`changed_at` AS `project_changed_at`, `p`.`count_likes`, `p`.`count_dislikes`, `p`.`laplace_score`, `p`.`member_id`, `p`.`cat_title` AS `catTitle`, `p`.`image_small`, (SELECT count(1) FROM `project_plings` `l` WHERE `p`.`project_id` = `l`.`project_id` AND `l`.`is_deleted` = 0 AND `l`.`is_active` = 1 ) `countplings` FROM `stat_projects` `p` WHERE `p`.`status` =100 AND `p`.`type_id` = 1 AND `featured` = 1 AND `p`.`member_id` = :member_id ORDER BY `p`.`changed_at` DESC "; if (isset($limit)) { $sql = $sql . ' limit ' . $limit; } if (isset($offset)) { $sql = $sql . ' offset ' . $offset; } $result = $this->_db->fetchAll($sql, array('member_id' => $member_id)); if ($result) { return $this->generateRowClass($result); } else { return null; } } /** * @param int $member_id * @param int|null $limit * @param int|null $offset * * @return null|Zend_Db_Table_Row_Abstract */ public function fetchAllCollectionsForMember($member_id, $limit = null, $offset = null) { // for member me page $sql = " SELECT `p`.`project_id`, `p`.`title`, `p`.`created_at` AS `project_created_at`, `p`.`changed_at` AS `project_changed_at`, `p`.`count_likes`, `p`.`count_dislikes`, `p`.`laplace_score`, `p`.`member_id`, `p`.`cat_title` AS `catTitle`, `p`.`image_small`, (SELECT count(1) FROM `project_plings` `l` WHERE `p`.`project_id` = `l`.`project_id` AND `l`.`is_deleted` = 0 AND `l`.`is_active` = 1 ) `countplings` FROM `stat_projects` `p` WHERE `p`.`status` =100 AND `p`.`type_id` = 3 AND `p`.`member_id` = :member_id ORDER BY `p`.`changed_at` DESC "; if (isset($limit)) { $sql = $sql . ' limit ' . $limit; } if (isset($offset)) { $sql = $sql . ' offset ' . $offset; } $result = $this->_db->fetchAll($sql, array('member_id' => $member_id)); if ($result) { return $this->generateRowClass($result); } else { return null; } } /** * @param string $orderby * @param int|null $limit * @param int|null $offset * * @return array */ public function fetchDuplicatedSourceProjects($orderby = 'source_url asc', $limit = null, $offset = null) { $sql = " SELECT `source_url` ,count(1) AS `cnt`, GROUP_CONCAT(`p`.`project_id` ORDER BY `p`.`created_at`) `pids` FROM `stat_projects_source_url` `p` GROUP BY `source_url` HAVING count(1)>1 "; if (isset($orderby)) { $sql = $sql . ' order by ' . $orderby; } if (isset($limit)) { $sql .= ' limit ' . (int)$limit; } if (isset($offset)) { $sql .= ' offset ' . (int)$offset; } $result = $this->_db->fetchAll($sql); return $result; } /** * @return mixed */ public function getTotalCountDuplicates() { $sql = " SELECT count(1) AS `cnt` FROM ( SELECT `source_url` ,count(1) AS `cnt`, GROUP_CONCAT(`p`.`project_id` ORDER BY `p`.`created_at`) `pids` FROM `stat_projects_source_url` `p` GROUP BY `p`.`source_url` HAVING count(1)>1 ) `a` "; $result = $this->_db->fetchAll($sql); return $result[0]['cnt'];; } /** * @param string $source_url * * @return mixed */ public function getCountSourceUrl($source_url) { $last = substr($source_url, -1); if ($last == '/') { $source_url = substr($source_url, 0, -1); } $sql = " SELECT count(1) AS `cnt` FROM `stat_projects_source_url` `p` WHERE `p`.`source_url`= :source_url "; $result = $this->_db->fetchAll($sql, array('source_url' => $source_url)); return $result[0]['cnt']; } public function getSourceUrlProjects($source_url) { $last = substr($source_url, -1); if ($last == '/') { $source_url = substr($source_url, 0, -1); } $sql = " SELECT p.project_id, pj.title, pj.member_id, pj.created_at, pj.changed_at, m.username FROM stat_projects_source_url p inner join project pj on p.project_id = pj.project_id and pj.status=100 inner join member m on pj.member_id = m.member_id WHERE p.source_url= :source_url "; $result = $this->_db->fetchAll($sql, array('source_url' => $source_url)); return $result; } /** * @param int $member_id * * @return mixed */ public function getCountProjectsDuplicateSourceurl($member_id) { $sql = " SELECT count(1) AS `cnt` FROM ( SELECT `p`.`source_url` ,(SELECT count(1) FROM `stat_projects_source_url` `pp` WHERE `pp`.`source_url`=`p`.`source_url`) `cnt` FROM `stat_projects_source_url` `p` WHERE `p`.`member_id` = :member_id ) `t` WHERE `t`.`cnt`>1 "; $result = $this->_db->fetchAll($sql, array('member_id' => $member_id)); return $result[0]['cnt']; } /** * @param $ids * * @return Zend_Db_Table_Row_Abstract * @throws Zend_Db_Statement_Exception */ public function fetchProjects($ids) { $sql = "SELECT * FROM stat_projects WHERE project_id in (" . $ids . ")"; $resultSet = $this->_db->fetchAll($sql); return $this->generateRowSet($resultSet); } /** * @param $project_id * @return true/false * @throws Zend_Db_Statement_Exception */ public function validateDeleteProjectFromSpam($project_id) { //produkt ist ueber 6 monate alt oder produkt hat ueber 5 kommentare oder produkt hat minimum 1 pling // darf nicht gelöscht werden $sql ='select count_comments ,created_at , (created_at+ INTERVAL 6 MONTH < NOW()) is_old ,(select count(1) from project_plings f where f.project_id = p.project_id and f.is_deleted = 0) plings FROM project p where project_id =:project_id'; $result = $this->_db->fetchRow($sql, array( 'project_id' => $project_id, )); if($result['count_comments'] >5 || $result['is_old'] ==1 || $result['plings']>0) { return false; } return true; } } diff --git a/application/modules/default/views/helpers/Image.php b/application/modules/default/views/helpers/Image.php index 98787a95a..ce50f98eb 100644 --- a/application/modules/default/views/helpers/Image.php +++ b/application/modules/default/views/helpers/Image.php @@ -1,126 +1,121 @@ . **/ class Default_View_Helper_Image extends Zend_View_Helper_Abstract { protected $_operations = array( 'crop' => '%d', 'width' => '%d', 'height' => '%d', 'quality' => '%d', 'bgColor' => '%s', 'progressive' => '%d' ); protected $_options = array( 'temporal' => false ); protected $_separator = '-'; public function Image($filename, $options = array()) { if (false === $this->validUri($filename)) { return $this->createImageUri($filename, $options); } $httpScheme = 'https'; - if (PHP_SAPI != 'cli') { - /** @var Zend_Controller_Request_Http $request */ - $request = Zend_Controller_Front::getInstance()->getRequest(); - $httpScheme = $request->getScheme(); - } $uri = $this->replaceScheme($filename, $httpScheme); if (empty($options)) { return $uri; } return $this->updateImageUri($uri, $options); } private function validUri($filename) { return Zend_Uri::check($filename); } private function createImageUri($filename, $options) { $operations = ""; if (isset($options['width']) && isset($options['height'])) { $operations .= $options['width'] . 'x' . $options['height']; } else { //$operations .= '80x80'; $operations .= ''; } if (isset($options['crop'])) { $operations .= '-' . $options['crop']; } else { //$operations .= '-2'; $operations .= ''; } if ($filename == "") { $filename = 'default.png'; } if (isset($options['temporal'])) { $filename = '/img/default/tmp/' . $filename; $url = $filename; } else { if (strpos($filename, '.gif') > 0 || $operations == '') { $url = IMAGES_MEDIA_SERVER . '/img/' . $filename; } else { $url = IMAGES_MEDIA_SERVER . '/cache/' . $operations . '/img/' . $filename; } } return $url; } private function replaceScheme($filename, $getScheme) { $result = preg_replace("|^https?|", $getScheme, $filename); return $result; } private function updateImageUri($filename, $options) { $dimension = ''; if (isset($options['width']) && isset($options['height'])) { $dimension = $options['width'] . 'x' . $options['height']; } else if (isset($options['width']) && (false === isset($options['height']))) { $dimension = $options['width'] . 'x' . $options['width']; } else if (isset($options['height']) && (false === isset($options['width']))) { $dimension = $options['height'] . 'x' . $options['height']; } $uri = preg_replace("/\d\d\dx\d\d\d/", $dimension, $filename); return $uri; } } \ No newline at end of file diff --git a/application/modules/default/views/scripts/product/add.phtml b/application/modules/default/views/scripts/product/add.phtml index 3a0bff40a..557099a1d 100644 --- a/application/modules/default/views/scripts/product/add.phtml +++ b/application/modules/default/views/scripts/product/add.phtml @@ -1,2186 +1,2186 @@ . **/ //$this->os = Zend_Registry::get('application_os'); $this->tab = 'add'; $helperImage = new Default_View_Helper_Image(); $helpMemberUrl = new Default_View_Helper_BuildMemberUrl(); $helpProductUrl = new Default_View_Helper_BuildProductUrl(); $helpBaseUrl = new Default_View_Helper_BuildBaseUrl(); $modelCategory = new Default_Model_DbTable_ProjectCategory(); $valueCatId = $this->form->project_category_id->getValue(); //$valueCatId = 55; $storeCatIds = Zend_Registry::isRegistered('store_category_list') ? Zend_Registry::get('store_category_list') : null; $categoryAncestors = $modelCategory->fetchAncestorsAsId($valueCatId); $categories = $modelCategory->fetchCategoriesForFormNew($valueCatId); $categoriesFallback = $modelCategory->fetchCategoriesForForm($valueCatId); //$categories2 = array(); if (count($categoryAncestors) > 0) { $categoryPath = explode(',',$categoryAncestors['ancestors']); } $categoryPath[] = $valueCatId; $this->headLink()->appendStylesheet('/theme/flatui/css/chosen.css'); $this->inlineScript()->appendFile('/theme/flatui/js/lib/chosen.jquery.min.js'); $this->inlineScript()->appendScript(' $(document).ready(function(){ $("select.chosen").chosen({ width: "100%", max_selected_options: "5", disable_search: "false", disable_search_threshold: "5" }); }); '); ?>
* $this->setAuth('shahar', 'secret', Zend_Http_Client::AUTH_BASIC);
*
*
* To disable authentication:
*
* $this->setAuth(false);
*
*
* @see http://www.faqs.org/rfcs/rfc2617.html
* @param string|false $user User name or false disable authentication
* @param string $password Password
* @param string $type Authentication type
* @return Zend_Http_Client
* @throws Zend_Http_Client_Exception
*/
public function setAuth($user, $password = '', $type = self::AUTH_BASIC)
{
// If we got false or null, disable authentication
if ($user === false || $user === null) {
$this->auth = null;
// Clear the auth information in the uri instance as well
if ($this->uri instanceof Zend_Uri_Http) {
$this->getUri()->setUsername('');
$this->getUri()->setPassword('');
}
// Else, set up authentication
} else {
// Check we got a proper authentication type
if (! defined('self::AUTH_' . strtoupper($type))) {
/** @see Zend_Http_Client_Exception */
// require_once 'Zend/Http/Client/Exception.php';
throw new Zend_Http_Client_Exception("Invalid or not supported authentication type: '$type'");
}
$this->auth = array(
'user' => (string) $user,
'password' => (string) $password,
'type' => $type
);
}
return $this;
}
/**
* Set the HTTP client's cookie jar.
*
* A cookie jar is an object that holds and maintains cookies across HTTP requests
* and responses.
*
* @param Zend_Http_CookieJar|boolean $cookiejar Existing cookiejar object, true to create a new one, false to disable
* @return Zend_Http_Client
* @throws Zend_Http_Client_Exception
*/
public function setCookieJar($cookiejar = true)
{
Zend_Loader::loadClass('Zend_Http_CookieJar');
if ($cookiejar instanceof Zend_Http_CookieJar) {
$this->cookiejar = $cookiejar;
} elseif ($cookiejar === true) {
$this->cookiejar = new Zend_Http_CookieJar();
} elseif (! $cookiejar) {
$this->cookiejar = null;
} else {
/** @see Zend_Http_Client_Exception */
// require_once 'Zend/Http/Client/Exception.php';
throw new Zend_Http_Client_Exception('Invalid parameter type passed as CookieJar');
}
return $this;
}
/**
* Return the current cookie jar or null if none.
*
* @return Zend_Http_CookieJar|null
*/
public function getCookieJar()
{
return $this->cookiejar;
}
/**
* Add a cookie to the request. If the client has no Cookie Jar, the cookies
* will be added directly to the headers array as "Cookie" headers.
*
* @param Zend_Http_Cookie|string $cookie
* @param string|null $value If "cookie" is a string, this is the cookie value.
* @return Zend_Http_Client
* @throws Zend_Http_Client_Exception
*/
public function setCookie($cookie, $value = null)
{
Zend_Loader::loadClass('Zend_Http_Cookie');
if (is_array($cookie)) {
foreach ($cookie as $c => $v) {
if (is_string($c)) {
$this->setCookie($c, $v);
} else {
$this->setCookie($v);
}
}
return $this;
}
if ($value !== null && $this->config['encodecookies']) {
$value = urlencode($value);
}
if (isset($this->cookiejar)) {
if ($cookie instanceof Zend_Http_Cookie) {
$this->cookiejar->addCookie($cookie);
} elseif (is_string($cookie) && $value !== null) {
$cookie = Zend_Http_Cookie::fromString("{$cookie}={$value}",
$this->uri,
$this->config['encodecookies']);
$this->cookiejar->addCookie($cookie);
}
} else {
if ($cookie instanceof Zend_Http_Cookie) {
$name = $cookie->getName();
$value = $cookie->getValue();
$cookie = $name;
}
if (preg_match("/[=,; \t\r\n\013\014]/", $cookie)) {
/** @see Zend_Http_Client_Exception */
// require_once 'Zend/Http/Client/Exception.php';
throw new Zend_Http_Client_Exception("Cookie name cannot contain these characters: =,; \t\r\n\013\014 ({$cookie})");
}
$value = addslashes($value);
if (! isset($this->headers['cookie'])) {
$this->headers['cookie'] = array('Cookie', '');
}
$this->headers['cookie'][1] .= $cookie . '=' . $value . '; ';
}
return $this;
}
/**
* Set a file to upload (using a POST request)
*
* Can be used in two ways:
*
* 1. $data is null (default): $filename is treated as the name if a local file which
* will be read and sent. Will try to guess the content type using mime_content_type().
* 2. $data is set - $filename is sent as the file name, but $data is sent as the file
* contents and no file is read from the file system. In this case, you need to
* manually set the Content-Type ($ctype) or it will default to
* application/octet-stream.
*
* @param string $filename Name of file to upload, or name to save as
* @param string $formname Name of form element to send as
* @param string $data Data to send (if null, $filename is read and sent)
* @param string $ctype Content type to use (if $data is set and $ctype is
* null, will be application/octet-stream)
* @return Zend_Http_Client
* @throws Zend_Http_Client_Exception
*/
public function setFileUpload($filename, $formname, $data = null, $ctype = null)
{
if ($data === null) {
if (($data = @file_get_contents($filename)) === false) {
/** @see Zend_Http_Client_Exception */
// require_once 'Zend/Http/Client/Exception.php';
throw new Zend_Http_Client_Exception("Unable to read file '{$filename}' for upload");
}
if (! $ctype) {
$ctype = $this->_detectFileMimeType($filename);
}
}
// Force enctype to multipart/form-data
$this->setEncType(self::ENC_FORMDATA);
$this->files[] = array(
'formname' => $formname,
'filename' => basename($filename),
'ctype' => $ctype,
'data' => $data
);
$this->body_field_order[$formname] = self::VTYPE_FILE;
return $this;
}
/**
* Set the encoding type for POST data
*
* @param string $enctype
* @return Zend_Http_Client
*/
public function setEncType($enctype = self::ENC_URLENCODED)
{
$this->enctype = $enctype;
return $this;
}
/**
* Set the raw (already encoded) POST data.
*
* This function is here for two reasons:
* 1. For advanced user who would like to set their own data, already encoded
* 2. For backwards compatibilty: If someone uses the old post($data) method.
* this method will be used to set the encoded data.
*
* $data can also be stream (such as file) from which the data will be read.
*
* @param string|resource $data
* @param string $enctype
* @return Zend_Http_Client
*/
public function setRawData($data, $enctype = null)
{
$this->raw_post_data = $data;
$this->setEncType($enctype);
if (is_resource($data)) {
// We've got stream data
$stat = @fstat($data);
if($stat) {
$this->setHeaders(self::CONTENT_LENGTH, $stat['size']);
}
}
return $this;
}
/**
* Set the unmask feature for GET parameters as array
*
* Example:
* foo%5B0%5D=a&foo%5B1%5D=b
* becomes
* foo=a&foo=b
*
* This is usefull for some services
*
* @param boolean $status
* @return Zend_Http_Client
*/
public function setUnmaskStatus($status = true)
{
$this->_unmaskStatus = (BOOL)$status;
return $this;
}
/**
* Returns the currently configured unmask status
*
* @return boolean
*/
public function getUnmaskStatus()
{
return $this->_unmaskStatus;
}
/**
* Clear all GET and POST parameters
*
* Should be used to reset the request parameters if the client is
* used for several concurrent requests.
*
* clearAll parameter controls if we clean just parameters or also
* headers and last_*
*
* @param bool $clearAll Should all data be cleared?
* @return Zend_Http_Client
*/
public function resetParameters($clearAll = false)
{
// Reset parameter data
$this->paramsGet = array();
$this->paramsPost = array();
$this->files = array();
$this->raw_post_data = null;
$this->enctype = null;
if($clearAll) {
$this->headers = array();
$this->last_request = null;
$this->last_response = null;
} else {
// Clear outdated headers
if (isset($this->headers[strtolower(self::CONTENT_TYPE)])) {
unset($this->headers[strtolower(self::CONTENT_TYPE)]);
}
if (isset($this->headers[strtolower(self::CONTENT_LENGTH)])) {
unset($this->headers[strtolower(self::CONTENT_LENGTH)]);
}
}
return $this;
}
/**
* Get the last HTTP request as string
*
* @return string
*/
public function getLastRequest()
{
return $this->last_request;
}
/**
* Get the last HTTP response received by this client
*
* If $config['storeresponse'] is set to false, or no response was
* stored yet, will return null
*
* @return Zend_Http_Response or null if none
*/
public function getLastResponse()
{
return $this->last_response;
}
/**
* Load the connection adapter
*
* While this method is not called more than one for a client, it is
* seperated from ->request() to preserve logic and readability
*
* @param Zend_Http_Client_Adapter_Interface|string $adapter
* @return null
* @throws Zend_Http_Client_Exception
*/
public function setAdapter($adapter)
{
if (is_string($adapter)) {
try {
Zend_Loader::loadClass($adapter);
} catch (Zend_Exception $e) {
/** @see Zend_Http_Client_Exception */
// require_once 'Zend/Http/Client/Exception.php';
throw new Zend_Http_Client_Exception("Unable to load adapter '$adapter': {$e->getMessage()}", 0, $e);
}
$adapter = new $adapter;
}
if (! $adapter instanceof Zend_Http_Client_Adapter_Interface) {
/** @see Zend_Http_Client_Exception */
// require_once 'Zend/Http/Client/Exception.php';
throw new Zend_Http_Client_Exception('Passed adapter is not a HTTP connection adapter');
}
$this->adapter = $adapter;
$config = $this->config;
unset($config['adapter']);
$this->adapter->setConfig($config);
}
/**
* Load the connection adapter
*
* @return Zend_Http_Client_Adapter_Interface $adapter
*/
public function getAdapter()
{
if (null === $this->adapter) {
$this->setAdapter($this->config['adapter']);
}
return $this->adapter;
}
/**
* Set streaming for received data
*
* @param string|boolean $streamfile Stream file, true for temp file, false/null for no streaming
* @return Zend_Http_Client
*/
public function setStream($streamfile = true)
{
$this->setConfig(array("output_stream" => $streamfile));
return $this;
}
/**
* Get status of streaming for received data
* @return boolean|string
*/
public function getStream()
{
return $this->config["output_stream"];
}
/**
* Create temporary stream
*
* @return resource
*/
protected function _openTempStream()
{
$this->_stream_name = $this->config['output_stream'];
if(!is_string($this->_stream_name)) {
// If name is not given, create temp name
$this->_stream_name = tempnam(isset($this->config['stream_tmp_dir'])?$this->config['stream_tmp_dir']:sys_get_temp_dir(),
'Zend_Http_Client');
}
if (false === ($fp = @fopen($this->_stream_name, "w+b"))) {
if ($this->adapter instanceof Zend_Http_Client_Adapter_Interface) {
$this->adapter->close();
}
// require_once 'Zend/Http/Client/Exception.php';
throw new Zend_Http_Client_Exception("Could not open temp file {$this->_stream_name}");
}
return $fp;
}
/**
* Send the HTTP request and return an HTTP response object
*
* @param string $method
* @return Zend_Http_Response
* @throws Zend_Http_Client_Exception
*/
public function request($method = null)
{
if (! $this->uri instanceof Zend_Uri_Http) {
/** @see Zend_Http_Client_Exception */
// require_once 'Zend/Http/Client/Exception.php';
throw new Zend_Http_Client_Exception('No valid URI has been passed to the client');
}
if ($method) {
$this->setMethod($method);
}
$this->redirectCounter = 0;
$response = null;
// Make sure the adapter is loaded
if ($this->adapter == null) {
$this->setAdapter($this->config['adapter']);
}
// Send the first request. If redirected, continue.
do {
// Clone the URI and add the additional GET parameters to it
$uri = clone $this->uri;
if (! empty($this->paramsGet)) {
$query = $uri->getQuery();
if (! empty($query)) {
$query .= '&';
}
$query .= http_build_query($this->paramsGet, null, '&');
if ($this->config['rfc3986_strict']) {
$query = str_replace('+', '%20', $query);
}
// @see ZF-11671 to unmask for some services to foo=val1&foo=val2
if ($this->getUnmaskStatus()) {
if ($this->_queryBracketsEscaped) {
$query = preg_replace('/%5B(?:[0-9]|[1-9][0-9]+)%5D=/', '=', $query);
} else {
$query = preg_replace('/\\[(?:[0-9]|[1-9][0-9]+)\\]=/', '=', $query);
}
}
$uri->setQuery($query);
}
$body = $this->_prepareBody();
$headers = $this->_prepareHeaders();
// check that adapter supports streaming before using it
if(is_resource($body) && !($this->adapter instanceof Zend_Http_Client_Adapter_Stream)) {
/** @see Zend_Http_Client_Exception */
// require_once 'Zend/Http/Client/Exception.php';
throw new Zend_Http_Client_Exception('Adapter does not support streaming');
}
// Open the connection, send the request and read the response
$this->adapter->connect($uri->getHost(), $uri->getPort(),
($uri->getScheme() == 'https' ? true : false));
if($this->config['output_stream']) {
if($this->adapter instanceof Zend_Http_Client_Adapter_Stream) {
$stream = $this->_openTempStream();
$this->adapter->setOutputStream($stream);
} else {
/** @see Zend_Http_Client_Exception */
// require_once 'Zend/Http/Client/Exception.php';
throw new Zend_Http_Client_Exception('Adapter does not support streaming');
}
}
$this->last_request = $this->adapter->write($this->method,
$uri, $this->config['httpversion'], $headers, $body);
$response = $this->adapter->read();
if (! $response) {
/** @see Zend_Http_Client_Exception */
// require_once 'Zend/Http/Client/Exception.php';
throw new Zend_Http_Client_Exception('Unable to read response, or response is empty');
}
if($this->config['output_stream']) {
$streamMetaData = stream_get_meta_data($stream);
if ($streamMetaData['seekable']) {
rewind($stream);
}
// cleanup the adapter
$this->adapter->setOutputStream(null);
$response = Zend_Http_Response_Stream::fromStream($response, $stream);
$response->setStreamName($this->_stream_name);
if(!is_string($this->config['output_stream'])) {
// we used temp name, will need to clean up
$response->setCleanup(true);
}
} else {
$response = Zend_Http_Response::fromString($response);
}
if ($this->config['storeresponse']) {
$this->last_response = $response;
}
// Load cookies into cookie jar
if (isset($this->cookiejar)) {
$this->cookiejar->addCookiesFromResponse($response, $uri, $this->config['encodecookies']);
}
// If we got redirected, look for the Location header
if ($response->isRedirect() && ($location = $response->getHeader('location'))) {
// Avoid problems with buggy servers that add whitespace at the
// end of some headers (See ZF-11283)
$location = trim($location);
// Check whether we send the exact same request again, or drop the parameters
// and send a GET request
if ($response->getStatus() == 303 ||
((! $this->config['strictredirects']) && ($response->getStatus() == 302 ||
$response->getStatus() == 301))) {
$this->resetParameters();
$this->setMethod(self::GET);
}
// If we got a well formed absolute URI
if (($scheme = substr($location, 0, 6)) && ($scheme == 'http:/' || $scheme == 'https:')) {
$this->setHeaders('host', null);
$this->setUri($location);
} else {
// Split into path and query and set the query
if (strpos($location, '?') !== false) {
list($location, $query) = explode('?', $location, 2);
} else {
$query = '';
}
$this->uri->setQuery($query);
// Else, if we got just an absolute path, set it
if(strpos($location, '/') === 0) {
$this->uri->setPath($location);
// Else, assume we have a relative path
} else {
// Get the current path directory, removing any trailing slashes
$path = $this->uri->getPath();
$path = rtrim(substr($path, 0, strrpos($path, '/')), "/");
$this->uri->setPath($path . '/' . $location);
}
}
++$this->redirectCounter;
} else {
// If we didn't get any location, stop redirecting
break;
}
} while ($this->redirectCounter < $this->config['maxredirects']);
return $response;
}
/**
* Prepare the request headers
*
* @return array
*/
protected function _prepareHeaders()
{
$headers = array();
// Set the host header
if (! isset($this->headers['host'])) {
$host = $this->uri->getHost();
// If the port is not default, add it
if (! (($this->uri->getScheme() == 'http' && $this->uri->getPort() == 80) ||
($this->uri->getScheme() == 'https' && $this->uri->getPort() == 443))) {
$host .= ':' . $this->uri->getPort();
}
$headers[] = "Host: {$host}";
}
// Set the connection header
if (! isset($this->headers['connection'])) {
if (! $this->config['keepalive']) {
$headers[] = "Connection: close";
}
}
// Set the Accept-encoding header if not set - depending on whether
// zlib is available or not.
if (! isset($this->headers['accept-encoding'])) {
if (function_exists('gzinflate')) {
$headers[] = 'Accept-encoding: gzip, deflate';
} else {
$headers[] = 'Accept-encoding: identity';
}
}
// Set the Content-Type header
if (($this->method == self::POST || $this->method == self::PUT) &&
(! isset($this->headers[strtolower(self::CONTENT_TYPE)]) && isset($this->enctype))) {
$headers[] = self::CONTENT_TYPE . ': ' . $this->enctype;
}
// Set the user agent header
if (! isset($this->headers['user-agent']) && isset($this->config['useragent'])) {
$headers[] = "User-Agent: {$this->config['useragent']}";
}
// Set HTTP authentication if needed
if (is_array($this->auth)) {
$auth = self::encodeAuthHeader($this->auth['user'], $this->auth['password'], $this->auth['type']);
$headers[] = "Authorization: {$auth}";
}
// Load cookies from cookie jar
if (isset($this->cookiejar)) {
$cookstr = $this->cookiejar->getMatchingCookies($this->uri,
true, Zend_Http_CookieJar::COOKIE_STRING_CONCAT);
if ($cookstr) {
$headers[] = "Cookie: {$cookstr}";
}
}
// Add all other user defined headers
foreach ($this->headers as $header) {
list($name, $value) = $header;
if (is_array($value)) {
$value = implode(', ', $value);
}
$headers[] = "$name: $value";
}
return $headers;
}
/**
* Prepare the request body (for POST and PUT requests)
*
* @return string
* @throws Zend_Http_Client_Exception
*/
protected function _prepareBody()
{
// According to RFC2616, a TRACE request should not have a body.
if ($this->method == self::TRACE) {
return '';
}
if (isset($this->raw_post_data) && is_resource($this->raw_post_data)) {
return $this->raw_post_data;
}
// If mbstring overloads substr and strlen functions, we have to
// override it's internal encoding
if (function_exists('mb_internal_encoding') &&
((int) ini_get('mbstring.func_overload')) & 2) {
$mbIntEnc = mb_internal_encoding();
mb_internal_encoding('ASCII');
}
// If we have raw_post_data set, just use it as the body.
if (isset($this->raw_post_data)) {
$this->setHeaders(self::CONTENT_LENGTH, strlen($this->raw_post_data));
if (isset($mbIntEnc)) {
mb_internal_encoding($mbIntEnc);
}
return $this->raw_post_data;
}
$body = '';
// If we have files to upload, force enctype to multipart/form-data
if (count ($this->files) > 0) {
$this->setEncType(self::ENC_FORMDATA);
}
// If we have POST parameters or files, encode and add them to the body
if (count($this->paramsPost) > 0 || count($this->files) > 0) {
switch($this->enctype) {
case self::ENC_FORMDATA:
// Encode body as multipart/form-data
$boundary = '---ZENDHTTPCLIENT-' . md5(microtime());
$this->setHeaders(self::CONTENT_TYPE, self::ENC_FORMDATA . "; boundary={$boundary}");
// Encode all files and POST vars in the order they were given
foreach ($this->body_field_order as $fieldName=>$fieldType) {
switch ($fieldType) {
case self::VTYPE_FILE:
foreach ($this->files as $file) {
if ($file['formname']===$fieldName) {
$fhead = array(self::CONTENT_TYPE => $file['ctype']);
$body .= self::encodeFormData($boundary, $file['formname'], $file['data'], $file['filename'], $fhead);
}
}
break;
case self::VTYPE_SCALAR:
if (isset($this->paramsPost[$fieldName])) {
if (is_array($this->paramsPost[$fieldName])) {
$flattened = self::_flattenParametersArray($this->paramsPost[$fieldName], $fieldName);
foreach ($flattened as $pp) {
$body .= self::encodeFormData($boundary, $pp[0], $pp[1]);
}
} else {
$body .= self::encodeFormData($boundary, $fieldName, $this->paramsPost[$fieldName]);
}
}
break;
}
}
$body .= "--{$boundary}--\r\n";
break;
case self::ENC_URLENCODED:
// Encode body as application/x-www-form-urlencoded
$this->setHeaders(self::CONTENT_TYPE, self::ENC_URLENCODED);
$body = http_build_query($this->paramsPost, '', '&');
break;
default:
if (isset($mbIntEnc)) {
mb_internal_encoding($mbIntEnc);
}
/** @see Zend_Http_Client_Exception */
// require_once 'Zend/Http/Client/Exception.php';
throw new Zend_Http_Client_Exception("Cannot handle content type '{$this->enctype}' automatically." .
" Please use Zend_Http_Client::setRawData to send this kind of content.");
break;
}
}
// Set the Content-Length if we have a body or if request is POST/PUT
if ($body || $this->method == self::POST || $this->method == self::PUT) {
$this->setHeaders(self::CONTENT_LENGTH, strlen($body));
}
if (isset($mbIntEnc)) {
mb_internal_encoding($mbIntEnc);
}
return $body;
}
/**
* Helper method that gets a possibly multi-level parameters array (get or
* post) and flattens it.
*
* The method returns an array of (key, value) pairs (because keys are not
* necessarily unique. If one of the parameters in as array, it will also
* add a [] suffix to the key.
*
* This method is deprecated since Zend Framework 1.9 in favour of
* self::_flattenParametersArray() and will be dropped in 2.0
*
* @deprecated since 1.9
*
* @param array $parray The parameters array
* @param bool $urlencode Whether to urlencode the name and value
* @return array
*/
protected function _getParametersRecursive($parray, $urlencode = false)
{
// Issue a deprecated notice
trigger_error("The " . __METHOD__ . " method is deprecated and will be dropped in 2.0.",
E_USER_NOTICE);
if (! is_array($parray)) {
return $parray;
}
$parameters = array();
foreach ($parray as $name => $value) {
if ($urlencode) {
$name = urlencode($name);
}
// If $value is an array, iterate over it
if (is_array($value)) {
$name .= ($urlencode ? '%5B%5D' : '[]');
foreach ($value as $subval) {
if ($urlencode) {
$subval = urlencode($subval);
}
$parameters[] = array($name, $subval);
}
} else {
if ($urlencode) {
$value = urlencode($value);
}
$parameters[] = array($name, $value);
}
}
return $parameters;
}
/**
* Attempt to detect the MIME type of a file using available extensions
*
* This method will try to detect the MIME type of a file. If the fileinfo
* extension is available, it will be used. If not, the mime_magic
* extension which is deprected but is still available in many PHP setups
* will be tried.
*
* If neither extension is available, the default application/octet-stream
* MIME type will be returned
*
* @param string $file File path
* @return string MIME type
*/
protected function _detectFileMimeType($file)
{
$type = null;
// First try with fileinfo functions
if (function_exists('finfo_open')) {
if (self::$_fileInfoDb === null) {
self::$_fileInfoDb = @finfo_open(FILEINFO_MIME);
}
if (self::$_fileInfoDb) {
$type = finfo_file(self::$_fileInfoDb, $file);
}
} elseif (function_exists('mime_content_type')) {
$type = mime_content_type($file);
}
// Fallback to the default application/octet-stream
if (! $type) {
$type = 'application/octet-stream';
}
return $type;
}
/**
* Encode data to a multipart/form-data part suitable for a POST request.
*
* @param string $boundary
* @param string $name
* @param mixed $value
* @param string $filename
* @param array $headers Associative array of optional headers @example ("Content-Transfer-Encoding" => "binary")
* @return string
*/
public static function encodeFormData($boundary, $name, $value, $filename = null, $headers = array())
{
$ret = "--{$boundary}\r\n" .
'Content-Disposition: form-data; name="' . $name .'"';
if ($filename) {
$ret .= '; filename="' . $filename . '"';
}
$ret .= "\r\n";
foreach ($headers as $hname => $hvalue) {
$ret .= "{$hname}: {$hvalue}\r\n";
}
$ret .= "\r\n";
$ret .= "{$value}\r\n";
return $ret;
}
/**
* Create a HTTP authentication "Authorization:" header according to the
* specified user, password and authentication method.
*
* @see http://www.faqs.org/rfcs/rfc2617.html
* @param string $user
* @param string $password
* @param string $type
* @return string
* @throws Zend_Http_Client_Exception
*/
public static function encodeAuthHeader($user, $password, $type = self::AUTH_BASIC)
{
$authHeader = null;
switch ($type) {
case self::AUTH_BASIC:
// In basic authentication, the user name cannot contain ":"
if (strpos($user, ':') !== false) {
/** @see Zend_Http_Client_Exception */
// require_once 'Zend/Http/Client/Exception.php';
throw new Zend_Http_Client_Exception("The user name cannot contain ':' in 'Basic' HTTP authentication");
}
$authHeader = 'Basic ' . base64_encode($user . ':' . $password);
break;
//case self::AUTH_DIGEST:
/**
* @todo Implement digest authentication
*/
// break;
default:
/** @see Zend_Http_Client_Exception */
// require_once 'Zend/Http/Client/Exception.php';
throw new Zend_Http_Client_Exception("Not a supported HTTP authentication type: '$type'");
}
return $authHeader;
}
/**
* Convert an array of parameters into a flat array of (key, value) pairs
*
* Will flatten a potentially multi-dimentional array of parameters (such
* as POST parameters) into a flat array of (key, value) paris. In case
* of multi-dimentional arrays, square brackets ([]) will be added to the
* key to indicate an array.
*
* @since 1.9
*
* @param array $parray
* @param string $prefix
* @return array
*/
protected static function _flattenParametersArray($parray, $prefix = null)
{
if (! is_array($parray)) {
return $parray;
}
$parameters = array();
foreach($parray as $name => $value) {
// Calculate array key
if ($prefix) {
if (is_int($name)) {
$key = $prefix . '[]';
} else {
$key = $prefix . "[$name]";
}
} else {
$key = $name;
}
if (is_array($value)) {
$parameters = array_merge($parameters, self::_flattenParametersArray($value, $key));
} else {
$parameters[] = array($key, $value);
}
}
return $parameters;
}
/**
* Ensure a header value is valid per RFC 7230.
*
* @see http://tools.ietf.org/html/rfc7230#section-3.2
* @param string|object|array $value
* @param bool $recurse
*/
protected function _validateHeaderValue($value, $recurse = true)
{
if (is_array($value) && $recurse) {
foreach ($value as $v) {
$this->_validateHeaderValue($v, false);
}
return;
}
// Cast integers and floats to strings for purposes of header representation.
if (is_int($value) || is_float($value)) {
$value = (string) $value;
}
if (! is_string($value) && (! is_object($value) || ! method_exists($value, '__toString'))) {
// require_once 'Zend/Http/Exception.php';
throw new Zend_Http_Exception('Invalid header value detected');
}
Zend_Http_Header_HeaderValue::assertValid($value);
}
}
diff --git a/sql_code/20160914_add_file_type.sql b/sql_code/20160914_add_file_type.sql
index 15e623b35..6204515cf 100644
--- a/sql_code/20160914_add_file_type.sql
+++ b/sql_code/20160914_add_file_type.sql
@@ -1,29 +1,35 @@
-CREATE TABLE `file_types` (
- `filetype_id` INT NOT NULL AUTO_INCREMENT,
- `text` VARCHAR(255) NOT NULL,
- `order` INT NULL,
- `is_active` INT(1) NULL DEFAULT '1',
- PRIMARY KEY (`filetype_id`)
+CREATE TABLE `file_types`
+(
+ `filetype_id` INT NOT NULL AUTO_INCREMENT,
+ `text` VARCHAR(255) NOT NULL,
+ `order` INT NULL,
+ `is_active` INT(1) NULL DEFAULT '1',
+ PRIMARY KEY (`filetype_id`)
)
-ENGINE=InnoDB
+ ENGINE = InnoDB
;
-CREATE TABLE `project_file_type` (
- `project_id` INT NOT NULL,
- `file_id` INT NOT NULL,
- `file_type_id` INT NOT NULL,
- PRIMARY KEY (`project_id`, `file_id`)
+CREATE TABLE `project_file_type`
+(
+ `project_id` INT NOT NULL,
+ `file_id` INT NOT NULL,
+ `file_type_id` INT NOT NULL,
+ PRIMARY KEY (`project_id`, `file_id`)
)
-ENGINE=InnoDB
+ ENGINE = InnoDB
;
-INSERT INTO `file_types` (`filetype_id`, `text`, `order`) VALUES ('1', 'AppImage', '1');
-INSERT INTO `file_types` (`filetype_id`, `text`, `order`) VALUES ('2', 'Android (APK)', '2');
-INSERT INTO `file_types` (`filetype_id`, `text`, `order`) VALUES ('3', 'OS X compatible', '3');
-INSERT INTO `file_types` (`filetype_id`, `text`, `order`) VALUES ('4', 'Windows executable', '4');
+INSERT INTO `file_types` (`filetype_id`, `text`, `order`)
+VALUES ('1', 'AppImage', '1');
+INSERT INTO `file_types` (`filetype_id`, `text`, `order`)
+VALUES ('2', 'Android (APK)', '2');
+INSERT INTO `file_types` (`filetype_id`, `text`, `order`)
+VALUES ('3', 'OS X compatible', '3');
+INSERT INTO `file_types` (`filetype_id`, `text`, `order`)
+VALUES ('4', 'Windows executable', '4');
ALTER TABLE `file_types`
-CHANGE COLUMN `text` `name` VARCHAR(255) NOT NULL ;
+ CHANGE COLUMN `text` `name` VARCHAR(255) NOT NULL;
ALTER TABLE `project_file_type`
-CHANGE COLUMN `file_type_id` `filetype_id` INT(11) NOT NULL ,
-ADD INDEX `idx_type_id` (`filetype_id` ASC);
\ No newline at end of file
+ CHANGE COLUMN `file_type_id` `filetype_id` INT(11) NOT NULL ,
+ ADD INDEX `idx_type_id` (`filetype_id` ASC);
\ No newline at end of file
diff --git a/sql_code/20160916_file_type_rename.sql b/sql_code/20160916_file_type_rename.sql
index 4f3ffe44a..5e94c13bb 100644
--- a/sql_code/20160916_file_type_rename.sql
+++ b/sql_code/20160916_file_type_rename.sql
@@ -1,7 +1,6 @@
-
ALTER TABLE `file_types`
-CHANGE COLUMN `text` `name` VARCHAR(255) NOT NULL ;
+ CHANGE COLUMN `text` `name` VARCHAR(255) NOT NULL;
ALTER TABLE `project_file_type`
-CHANGE COLUMN `file_type_id` `filetype_id` INT(11) NOT NULL ,
-ADD INDEX `idx_type_id` (`filetype_id` ASC);
\ No newline at end of file
+ CHANGE COLUMN `file_type_id` `filetype_id` INT(11) NOT NULL ,
+ ADD INDEX `idx_type_id` (`filetype_id` ASC);
\ No newline at end of file
diff --git a/sql_code/20160919_file_type_rename.sql b/sql_code/20160919_file_type_rename.sql
index aa4ae9005..19fb85e29 100644
--- a/sql_code/20160919_file_type_rename.sql
+++ b/sql_code/20160919_file_type_rename.sql
@@ -1,12 +1,12 @@
RENAME TABLE `file_types` TO `package_types`;
ALTER TABLE `package_types`
- CHANGE COLUMN `filetype_id` `package_type_id` INT(11) NOT NULL AUTO_INCREMENT FIRST;
+ CHANGE COLUMN `filetype_id` `package_type_id` INT(11) NOT NULL AUTO_INCREMENT FIRST;
ALTER TABLE `project_file_type`
- ALTER `filetype_id` DROP DEFAULT;
+ ALTER `filetype_id` DROP DEFAULT;
ALTER TABLE `project_file_type`
- CHANGE COLUMN `filetype_id` `package_type_id` INT(11) NOT NULL AFTER `file_id`;
+ CHANGE COLUMN `filetype_id` `package_type_id` INT(11) NOT NULL AFTER `file_id`;
RENAME TABLE `project_file_type` TO `project_package_type`;
diff --git a/sql_code/20160921_add_mail_template_comment_reply.sql b/sql_code/20160921_add_mail_template_comment_reply.sql
index e9d471a41..412c44f6b 100644
--- a/sql_code/20160921_add_mail_template_comment_reply.sql
+++ b/sql_code/20160921_add_mail_template_comment_reply.sql
@@ -1 +1,4 @@
-INSERT INTO `mail_template` (`name`, `subject`, `text`, `created_at`, `changed_at`) VALUES ('tpl_user_comment_reply_note', 'opendesktop.org - You received a new reply to your comment', '
you received a new reply to your comment on %product_title%
Here is what the user wrote:
Kind regards,
Your openDesktop Team
contact@opendesktop.org
you received a new reply to your comment on %product_title%
Here is what the user wrote:
Kind regards,
Your openDesktop Team
contact@opendesktop.org