"
. $desc
. '
';
}
$filter = parent::renderFilter();
$filter = preg_match('#()(.*)$#is', $filter, $matches);
return $matches[1] . $title . $matches[2];
}
public function renderInputs()
{
return $this->renderInputText(array(
'name' => 'filter',
'size' => 40,
'placeholder' => ___("Login/Name/Email/Invoice/Receipt/IP")));
}
public function initFilter(Am_Grid_ReadOnly $grid)
{
parent::initFilter($grid);
$query = $grid->getDataSource();
$query->setPrefix('_u_search');
/* @var $query Am_Query_User */
if ($id = $grid->getCompleteRequest()->getInt('_search_del')){
$query->deleteSaved($id);
Am_Mvc_Response::redirectLocation($this->getDi()->url('admin-users',null,false));
exit();
} elseif ($id = $grid->getRequest()->getInt('search_load')){
$query->load($id);
} elseif (is_string($this->vars['filter']) && $this->vars['filter']){
$cond = new Am_Query_User_Condition_Filter();
$cond->setFromRequest(array('filter' => array('val' => $this->vars['filter'])));
$event = new Am_Event(Am_Event::ADMIN_USERS_FILTER_INIT, array(
'query' => $query,
'filter' => $this->vars['filter']
));
$event->setReturn($cond);
Am_Di::getInstance()->hook->call($event);
$query->add($event->getReturn());
} else {
$query->setFromRequest($grid->getCompleteRequest());
}
}
public function isFiltered()
{
return (bool)$this->grid->getDataSource()->getConditions();
}
}
class Am_Grid_Field_Decorator_Additional extends Am_Grid_Field_Decorator_Abstract
{
/** @var Am_CustomField */
protected $f;
function __construct(Am_CustomField $f) {
$this->f = $f;
}
function render(& $out, $obj, $controller) {
$field = $this->f;
$val = $field->valueFromTable($out);
switch($field->getType()) {
case 'date':
$res = amDate($val);
break;
case 'select':
case 'radio':
case 'checkbox':
case 'multi_select':
$val = (array)$val;
foreach ($val as $k=>$v)
$val[$k] = @$field->options[$v];
$res = implode(", ", $val);
break;
default:
$res = $val;
}
$out = $controller->renderTd($res);
}
}
class AdminUsersController extends Am_Mvc_Controller_Grid
{
public function checkAdminPermissions(Admin $admin)
{
return $admin->hasPermission('grid_u');
}
public function preDispatch()
{
parent::preDispatch();
$this->setActiveMenu($this->getParam('_u_a')=='insert' ? 'users-insert' : 'users-browse');
}
function dataAction()
{
$this->getDi()->authAdmin->getUser()->checkPermission('grid_u', 'browse');
$user = $this->getDi()->userTable->load($this->_request->getInt('user_id'));
$this->getResponse()->setHeader('Content-type', 'text/xml');
$x = new XMLWriter();
$x->openMemory();
$x->setIndent(true);
$x->startElement('user-data-items');
$this->writeEl($x, $user->data()->getAll());
$x->endElement();
echo $x->flush();
}
function writeEl(XMLWriter $x, $val) {
if (is_scalar($val)) {
$x->text($val);
} elseif(is_array($val)) {
foreach ($val as $k => $v) {
$x->startElement('item');
$x->writeAttribute('name', $k);
$this->writeEl($x, $v);
$x->endElement();
}
}
}
public function disableAutoLockAction()
{
$this->getDi()->authAdmin->getUser()->checkPermission('grid_u', 'edit');
$id = $this->getParam('id');
$user = $this->getDi()->userTable->load($id);
if (!$user)
throw new Am_Exception_InputError;
$user->updateQuick('disable_lock_until', sqlTime('+1 day'));
$b = $this->getParam('b', $this->view->userUrl($user->pk()));
$this->_response->redirectLocation($b);
}
public function deleteAction()
{
$this->getDi()->authAdmin->getUser()->checkPermission('grid_u', 'delete');
if ($this->getRequest()->isPost()) {
$user = $this->getDi()->userTable->load($this->getParam('id'));
$user->delete();
$this->getDi()->adminLogTable->log(
sprintf('%s (%s, %s, %s)', ___('Delete User'), $user->getName(), $user->login, $user->email),
'grid_u', $user->pk());
$this->_response->redirectLocation($this->getDi()->url('admin-users',null,false));
} else {
$this->view->user = $this->getDi()->userTable->load($this->getParam('id'));
$this->view->display('admin/user-delete.phtml');
}
}
public function getNotConfirmedCount()
{
return $this->getDi()->db->selectCell("SELECT COUNT(*) FROM ?_store
WHERE name LIKE 'signup_record-%' AND CHAR_LENGTH(blob_value)>10 AND expires>?",
$this->getDi()->sqlDateTime);
}
public function notConfirmedAction()
{
$arr = array();
foreach ($this->getDi()->db->select("SELECT `blob_value`, expires FROM ?_store
WHERE name LIKE 'signup_record-%' AND CHAR_LENGTH(blob_value)>10 AND expires>?",
$this->getDi()->sqlDateTime) as $row)
{
$v = unserialize($row['blob_value']);
$rec = array();
foreach ($v['values'] as $page)
{
$rec = array_merge($rec, $page);
}
$rec['expires'] = $row['expires'];
$link = Am_Html::escape($v['opaque']['ConfirmUrl']);
$rec['link'] = 'Give this link to customer if e-mail confirmation has not been received:'.
'
' . $link . '
';
if (empty($rec['login'])) $rec['login'] = null;
if (empty($rec['name_f'])) $rec['name_f'] = null;
if (empty($rec['name_l'])) $rec['name_l'] = null;
$arr[] = (object)$rec;
}
$ds = new Am_Grid_DataSource_Array($arr);
$grid = new Am_Grid_Editable('_usernc', ___("Not Confirmed Users"),
$ds, $this->_request, $this->view, $this->getDi());
$grid->setPermissionId('grid_u');
$grid->addField('login', ___('Username'));
$grid->addField('email', ___('E-Mail'));
$grid->addField('name_f', ___('First Name'));
$grid->addField('name_l', ___('Last Name'));
$grid->addField(new Am_Grid_Field_Date('expires', ___('Expires')))->setFormatDate();
$grid->addField(new Am_Grid_Field_Expandable('link', ___('Link')))->setEscape(false);
$grid->actionsClear();
$this->view->content = $grid->runWithLayout('admin/layout.phtml');
}
public function autocompleteAction()
{
$term = '%' . $this->getParam('term') . '%';
if (!$term) return null;
$q = new Am_Query($this->getDi()->userTable);
$q->addWhere('(t.login LIKE ?) OR (t.email LIKE ?) OR (t.name_f LIKE ?) OR (t.name_l LIKE ?)',
$term, $term, $term, $term);
$this->getDi()->hook->call(Am_Event::ADMIN_USERS_AUTOCOMPLETE, array(
'query' => $q,
'term' => $term
));
$qq = $q->query(0, 10);
$ret = array();
while ($r = $this->getDi()->db->fetchRow($qq))
{
$ret[] = array
(
'label' => sprintf('%s / "%s" <%s>', $r['login'], $r['name_f'] . ' ' . $r['name_l'], $r['email']),
'value' => $r['login'],
'url' => $this->view->userUrl($r['user_id'])
);
}
if ($q->getFoundRows() > 10)
$ret[] = array(
'label' => sprintf("... %d more rows found ...", $q->getFoundRows() - 10),
'value' => null,
'url' => $this->url('admin-users', array('_u_filter' => $this->getParam('term')), false)
);
$this->_response->ajaxResponse($ret);
}
public function indexAction()
{
if (in_array($this->grid->getCurrentAction(), array('edit','insert')))
$this->layout = 'admin/user-layout.phtml';
parent::indexAction();
}
public function createGrid()
{
$ds = new Am_Query_User;
$datetime = $this->getDi()->sqlDate;
$ds->addField("concat(u.name_f, ' ', u.name_l)", '_name')
->addField('(SELECT COUNT(p.invoice_payment_id) FROM ?_invoice_payment p WHERE p.user_id = u.user_id)', '_payments_count')
->addField('(SELECT ROUND(SUM((p.amount - IFNULL(p.refund_amount, 0))/p.base_currency_multi), 2)
FROM ?_invoice_payment p WHERE p.user_id = u.user_id)', '_payments_sum')
->addField("(SELECT MAX(expire_date) FROM ?_access ac WHERE ac.user_id = u.user_id)", '_expire')
->addField("(SELECT GROUP_CONCAT(title SEPARATOR ', ') FROM ?_access ac
LEFT JOIN ?_product p USING (product_id)
WHERE ac.user_id = u.user_id AND ac.begin_date<='$datetime' AND ac.expire_date>='$datetime')", '_products')
->addField("(SELECT GROUP_CONCAT(title SEPARATOR ', ') FROM ?_user_user_group uug
LEFT JOIN ?_user_group ug USING (user_group_id)
WHERE uug.user_id = u.user_id)", '_ugroup');
$ds->setOrder("login");
$grid = new Am_Grid_Editable('_u', ___("Browse Users"), $ds, $this->_request, $this->view);
$grid->setRecordTitle(array($this, 'getRecordTitle'));
$_ = $grid->addField(new Am_Grid_Field('login', ___('Username'), true));
if ($this->getDi()->authAdmin->getUser()->hasPermission('grid_u', 'edit')) {
$_->setRenderFunction(array($this, 'renderLogin'));
}
$grid->addField(new Am_Grid_Field('_name', ___('Name'), true));
$grid->addField(new Am_Grid_Field('email', ___('E-Mail Address'), true))
->setRenderFunction(array($this, 'renderEmail'));
$grid->addField(new Am_Grid_Field('_payments_sum', ___('Payments'), true, null, array($this, 'renderPayments')));
$grid->addField('status', ___('Status'), true)->setRenderFunction(array($this, 'renderStatus'));
$grid->actionAdd($this->createActionExport());
$grid->actionGet('edit')->setTarget('_top')->showFormAfterSave(true);
$grid->actionGet('insert')->setTarget('_top')->showFormAfterSave(true);
$grid->setForm(array($this, 'createForm'));
$grid->addCallback(Am_Grid_Editable::CB_BEFORE_SAVE, array($this, 'beforeSave'));
$grid->addCallback(Am_Grid_Editable::CB_AFTER_SAVE, array($this, 'afterSave'));
$grid->addCallback(Am_Grid_Editable::CB_VALUES_TO_FORM, array($this, 'valuesToForm'));
$grid->addCallback(Am_Grid_Editable::CB_RENDER_STATIC, array($this, 'renderStatic'));
$grid->addCallback(Am_Grid_ReadOnly::CB_TR_ATTRIBS, array($this, 'getTrAttribs'));
$grid->actionAdd($this->createActionCustomize());
$grid->actionAdd(new Am_Grid_Action_Group_Callback('lock', ___("Lock"), array($this, 'lockUser')));
$grid->actionAdd(new Am_Grid_Action_Group_Callback('unlock', ___("Unlock"), array($this, 'unlockUser')));
$grid->actionAdd(new Am_Grid_Action_Group_Callback('approve', ___("Approve"), array($this, 'approveUser')));
$grid->actionAdd(new Am_Grid_Action_Group_Callback('unsubscribe', ___("Unsubscribe from All Emails"), array($this, 'unsubscribeUser')));
$grid->actionAdd(new Am_Grid_Action_Group_EmailUsers());
$grid->actionAdd(new Am_Grid_Action_Group_MassSubscribe());
$grid->actionAdd(new Am_Grid_Action_Group_PasswordConfirmedDelete());
$grid->actionDelete('delete');
$grid->actionAdd(new Am_Grid_Action_LoginAs('login', ___('Login as User'),
'__ROOT__/admin-users/login-as?id=__ID__'))->setTarget('_blank');
$grid->actionAdd(new Am_Grid_Action_Delete());
$grid->actionAdd(new Am_Grid_Action_Merge());
$grid->actionAdd(new Am_Grid_Action_Group_UserAssignGroup(false));
$grid->actionAdd(new Am_Grid_Action_Group_UserAssignGroup(true));
$nc_count = $this->getDi()->cache->load('getNotConfirmedCount');
if ($nc_count === false)
{
$nc_count = $this->getNotConfirmedCount();
$this->getDi()->cache->save($nc_count, 'getNotConfirmedCount', array(), 60);
}
if ($nc_count)
{
$grid->actionAdd(new Am_Grid_Action_Url('not-confirmed',
___("Not Confirmed Users") . " ($nc_count)",
$this->getDi()->url('admin-users/not-confirmed',null,false)))
->setType(Am_Grid_Action_Abstract::NORECORD)
->setCssClass('link')
->setTarget('_top');
}
$grid->actionAdd(new Am_Grid_Action_Url('import', ___('Import Users'), 'admin-import'))
->setType(Am_Grid_Action_Abstract::NORECORD)
->setTarget('_top')
->setCssClass('link')
->setPrivilegeId('insert');
$grid->setFilter(new Am_Grid_Filter_User());
$grid->setEventId('gridUser');
return $grid;
}
public function getRecordTitle(User $user = null)
{
return $user ? sprintf('%s - %s', ___('User'), implode(", ", array_filter(array($user->getName(), $user->login, $user->email)))) : ___('User');
}
public function getTrAttribs(& $ret, $record)
{
if ($record->isLocked()
|| (!$record->isApproved()))
{
$ret['class'] = isset($ret['class']) ? $ret['class'] . ' disabled' : 'disabled';
}
}
protected function createActionCustomize()
{
$stateTitleField = new Am_Grid_Field('state_title', ___('State Title'), false);
$stateTitleField->setGetFunction(array($this, 'getStateTitle'));
$countryTitleField = new Am_Grid_Field('country_title', ___('Country Title'), false);
$countryTitleField->setGetFunction(array($this, 'getCountryTitle'));
$lastSigninInfoField = new Am_Grid_Field('last_signin', ___('Last Signin Info'), false);
$lastSigninInfoField->setGetFunction(array($this, 'getLastSigninInfo'));
$gravatarField = new Am_Grid_Field('gravatar', ___('Gravatar'), false, null, array($this, 'renderGravatar'), '1%');
$expireField = new Am_Grid_Field_Date('_expire', ___('Expire'));
$expireField->setFormatDate();
$productsField = new Am_Grid_Field_Expandable('_products', ___('Active Subscriptions'));
$productsField->setPlaceholder(Am_Grid_Field_Expandable::PLACEHOLDER_SELF_TRUNCATE_END)
->setMaxLength(50)
->setGetFunction(function($r, $g, $f) {
return strip_tags($r->$f);
});
$userGroupField = new Am_Grid_Field('_ugroup', ___('User Groups'), false);
$isAffField = new Am_Grid_Field_Enum('is_affiliate', ___('Is Affiliate?'));
$isAffField->setTranslations(array(0 => ___('No'), 1 => ___('Yes'), 2 => ___('Yes')));
$action = new Am_Grid_Action_Customize();
$action->addField(new Am_Grid_Field('user_id', '#', true, '', null, '1%'))
->addField(new Am_Grid_Field('name_f', ___('First Name')))
->addField(new Am_Grid_Field('name_l', ___('Last Name')))
->addField(new Am_Grid_Field('street', ___('Street')))
->addField(new Am_Grid_Field('street2', ___('Street (Second Line)')))
->addField(new Am_Grid_Field('city', ___('City')))
->addField(new Am_Grid_Field('state', ___('State')))
->addField($stateTitleField)
->addField(new Am_Grid_Field('zip', ___('ZIP Code')))
->addField(new Am_Grid_Field('country', ___('Country')))
->addField($countryTitleField)
->addField(new Am_Grid_Field('phone', ___('Phone')))
->addField(new Am_Grid_Field_Date('added', ___('Added')))
->addField($productsField)
->addField($userGroupField)
->addField(new Am_Grid_Field('status', ___('Status')))
->addField(new Am_Grid_Field('unsubscribed', ___('Unsubscribed')))
->addField(new Am_Grid_Field('lang', ___('Language')))
->addField(new Am_Grid_Field('is_locked', ___('Is Locked')))
->addField(new Am_Grid_Field('comment', ___('Comment')))
->addField(new Am_Grid_Field('aff_id', ___('Affiliate Id#')))
->addField($isAffField)
->addField($expireField)
->addField($lastSigninInfoField)
->addField($gravatarField);
//Additional Fields
foreach ($this->getDi()->userTable->customFields()->getAll() as $field) {
if (isset($field->from_config) && $field->from_config) {
$f = $field->sql ?
new Am_Grid_Field($field->name, $field->title) :
new Am_Grid_Field_Data($field->name, $field->title, false);
$f->addDecorator(new Am_Grid_Field_Decorator_Additional($field));
$f->setRenderFunction(array($this, 'renderAdditional'));
$action->addField($f);
}
}
return $action;
}
function renderAdditional($record, $fieldName, $controller, $field)
{
//@see Am_Grid_Field_Decorator_Additional
return $field->get($record, $controller, $fieldName);
}
function renderGravatar($record, $fieldName, $controller, $field)
{
return sprintf('
| ',
'//www.gravatar.com/avatar/' . md5(strtolower(trim($record->email))) . '?s=40&d=mm');
}
function renderEmail($record, $fieldName, $controller, $field)
{
return $controller->renderTd(sprintf('
%s',
$this->getDi()->url("admin-email",
array(
'search-type'=>'advanced',
'search'=>json_encode(array('member_id_filter'=>array('val'=>$record->pk())))
)
),
$this->escape($record->email)), false);
}
protected function createActionExport() {
$stateTitleField = new Am_Grid_Field('state_title', ___('State Title'));
$stateTitleField->setGetFunction(array($this, 'getStateTitle'));
$countryTitleField = new Am_Grid_Field('country_title', ___('Country Title'));
$countryTitleField->setGetFunction(array($this, 'getCountryTitle'));
$lastSigninInfoField = new Am_Grid_Field('last_signin', ___('Last Signin Info'));
$lastSigninInfoField->setGetFunction(array($this, 'getLastSigninInfo'));
$action = new Am_Grid_Action_Export();
$action->addField(new Am_Grid_Field('user_id', ___('User Id')))
->addField(new Am_Grid_Field('login', ___('Username')))
->addField(new Am_Grid_Field('email', ___('Email')))
->addField(new Am_Grid_Field('pass', ___('Password Hash')))
->addField(new Am_Grid_Field('name_f', ___('First Name')))
->addField(new Am_Grid_Field('name_l', ___('Last Name')))
->addField(new Am_Grid_Field('street', ___('Street')))
->addField(new Am_Grid_Field('street2', ___('Street (Second Line)')))
->addField(new Am_Grid_Field('city', ___('City')))
->addField(new Am_Grid_Field('state', ___('State')))
->addField($stateTitleField)
->addField(new Am_Grid_Field('zip', ___('ZIP Code')))
->addField(new Am_Grid_Field('country', ___('Country')))
->addField($countryTitleField)
->addField(new Am_Grid_Field('phone', ___('Phone')))
->addField(new Am_Grid_Field('added', ___('Added')))
->addField(new Am_Grid_Field('status', ___('Status')))
->addField(new Am_Grid_Field('_ugroup', ___('User Groups')))
->addField(new Am_Grid_Field('_products', ___('Active Subscriptions')))
->addField(new Am_Grid_Field('unsubscribed', ___('Unsubscribed')))
->addField(new Am_Grid_Field('lang', ___('Language')))
->addField(new Am_Grid_Field('is_locked', ___('Is Locked')))
->addField(new Am_Grid_Field('comment', ___('Comment')))
->addField(new Am_Grid_Field('aff_id', ___('Affiliate Id#')))
->addField(new Am_Grid_Field('_payments_sum', ___('Payments (amount of all payments made by user minus refunds)')))
->addField(new Am_Grid_Field('_expire', ___('Expire (maximum expiration date)')))
->addField($lastSigninInfoField);
//Additional Fields
foreach ($this->getDi()->userTable->customFields()->getAll() as $field) {
if (isset($field->from_config) && $field->from_config) {
if ($field->sql) {
if(in_array($field->type, array('multi_select','checkbox'))){
$f = new Am_Grid_Field($field->name, $field->title . ' (Value)');
$f->setGetFunction(array($this,'getMultiSelect'));
$action->addField($f);
$op = $field->options;
$fn = $field->name;
$f = new Am_Grid_Field($field->name . '_label', $field->title . ' (Label)');
$f->setGetFunction(function($obj, $controller, $field=null) use ($op, $fn){
return implode(',', array_map(function($el) use ($op) {
return isset($op[$el]) ? $op[$el] : $el;
}, (array)$obj->{$fn}));
});
$action->addField($f);
} else {
$action->addField(new Am_Grid_Field($field->name, $field->title));
}
} else {
if(in_array($field->type, array('multi_select','checkbox'))){
//we use trailing __blob to distinguish multi select fields from data table
$mfield = new Am_Grid_Field($field->name . '__blob', $field->title . ' (Value)');
$mfield->setGetFunction(array($this,'getMultiSelect'));
$action->addField($mfield);
$op = $field->options;
$fn = $field->name . '__blob';
$f = new Am_Grid_Field($field->name . '_label__blob', $field->title . ' (Label)');
$f->setGetFunction(function($obj, $controller, $field=null) use ($op, $fn){
return implode(',', array_map(function($el) use ($op) {
return isset($op[$el]) ? $op[$el] : $el;
}, (array)@unserialize($obj->{$fn})));
});
$action->addField($f);
}
else
//we use trailing __ to distinguish fields from data table
$action->addField(new Am_Grid_Field($field->name . '__', $field->title));
}
}
}
$action->setGetDataSourceFunc(array($this, 'getDS'));
return $action;
}
function getStateTitle($obj, $controller, $field=null)
{
return $this->getDi()->stateTable->getTitleByCode($obj->country, $obj->state);
}
function getCountryTitle($obj, $controller, $field=null)
{
return $this->getDi()->countryTable->getTitleByCode($obj->country);
}
function getLastSigninInfo($obj, $controller, $field=null)
{
return $obj->last_login ? $obj->last_ip . ___(' at ') . amDatetime($obj->last_login) : ___('Never');
}
function getMultiSelect($obj, $controller, $field=null)
{
return implode(',', is_array($obj->{$field}) ? $obj->{$field} : (array)@unserialize($obj->{$field}));
}
public function getDS(Am_Query $ds, $fields) {
$i = 0;
//join only selected fields
foreach ($fields as $field) {
$fn = $field->getFieldName();
if (substr($fn, -6) == '__blob') { //multi select field from data table
$i++;
$field_name = substr($fn, 0, strlen($fn)-6);
$ds = $ds->leftJoin("?_data", "d$i", "u.user_id = d$i.id AND d$i.table='user' AND d$i.key='$field_name'")
->addField("d$i.blob", $fn);
}
if (substr($fn, -2) == '__') { //field from data table
$i++;
$field_name = substr($fn, 0, strlen($fn)-2);
$ds = $ds->leftJoin("?_data", "d$i", "u.user_id = d$i.id AND d$i.table='user' AND d$i.key='$field_name'")
->addField("d$i.value", $fn);
}
}
return $ds;
}
public function renderStatic(& $out, Am_Grid_Editable $grid)
{
$hidden = Am_Html::renderArrayAsInputHiddens($grid->getFilter()->getAllButFilterVars());
$out .=
"\n" .
$grid->getDataSource()->renderForm($hidden) . "\n";
"\n";
}
public function lockUser($id, User $user)
{
$user->lock(true);
}
public function unlockUser($id, User $user)
{
$user->lock(false);
}
public function subscribeUser($id, User $user)
{
$user->unsubscribed = 0;
$user->save();
}
public function unsubscribeUser($id, User $user)
{
$user->unsubscribed = 1;
$user->save();
}
public function approveUser($id, User $user)
{
$user->approve();
}
function renderLogin($record)
{
$icons = "";
if ($record->isLocked())
$icons .= $this->view->icon('user-locked', ___('User is locked'));
if (!$record->isApproved())
$icons .= $this->view->icon('user-not-approved', ___('User is not approved'));
if ($icons) $icons = '
' . $icons . '
';
return $this->renderTd(sprintf('%s
%s',
$icons,
$this->escape($this->grid->getActionUrl('edit', $record->user_id)),
$this->escape($record->login)), false);
}
function renderStatus(User $record)
{
$text = "";
switch ($record->status)
{
case User::STATUS_PENDING:
if ($record->_payments_count) {
if ((float)$record->_payments_sum > 0) {
$text = '
' . ___('Future') . '';
} else {
$text = '
' . ___('Refunded') . '';
}
} else {
$text = '
' . ___('Pending') . '';
}
break;
case User::STATUS_ACTIVE:
$text = '
' . ___('Active') . '';
break;
case User::STATUS_EXPIRED:
$text = '
' . ___('Expired') . '';
break;
}
return $this->renderTd($text, false);
}
function renderPayments(User $record)
{
if ($record->_payments_count)
{
$curr = new Am_Currency();
$curr->setValue($record->_payments_sum);
$text = $record->_payments_count . ' - ' . $curr->toString();
$link = $this->getDi()->url("admin-user-payments/index/user_id/{$record->user_id}");
$text = sprintf('
%s', $link, $text);
} else {
$text = ___('Never');
}
return sprintf('
%s | ', $text);
}
function createForm()
{
return new Am_Form_Admin_User($this->grid->getRecord());
}
function saveSearchAction()
{
$q = new Am_Query_User();
$search = $this->_request->get('search');
$q->unserialize($search['serialized']);
if (!$q->getConditions())
throw new Am_Exception_InputError("Wrong parameters passed: no conditions : " . htmlentities($this->_request->search['serialized']));
if (!strlen($this->getParam('name')))
throw new Am_Exception_InputError(___("No search name passed"));
$name = $this->getParam('name');
$id = $q->setName($name)->save();
$this->_response->redirectLocation($this->getDi()->url('admin-users',array('_u_search_load'=>$id),false));
}
function valuesToForm(& $values, User $record)
{
$values['_groups'] = $record->getGroups();
}
function beforeSave(array &$values, User $record)
{
if (!empty($values['_pass']))
$record->setPass($values['_pass']);
if (!$record->isLoaded()) $record->is_approved = 1;
}
function afterSave(array &$values, User $record)
{
if(($this->grid->getCurrentAction() == 'insert') && @$values['_registration_mail']) {
$record->sendRegistrationEmail();
}
$record->setGroups(array_filter((array)@$values['_groups']));
//bind upload ids to current user
$upload_ids = array();
foreach ($this->getDi()->userTable->customFields()->getAll() as $f) {
if (in_array($f->type, array('upload', 'multi_upload'))) {
$upload_ids = array_merge($upload_ids,
(array)($f->sql ? $record->{$f->name} : $record->data()->get($f->name)));
}
}
if ($upload_ids) {
$this->getDi()->db->query(<<
pk(), $this->getDi()->authAdmin->getUserId(), $upload_ids);
}
// if ($this->grid->hasPermission(null, 'edit'))
// {
// $this->_response->redirectLocation($this->getView()->userUrl($record->pk()));
// exit();
// }
}
function loginAsAction()
{
if (!$this->getDi()->authAdmin->getUser()->hasPermission('grid_u', 'login-as'))
throw new Am_Exception_AccessDenied();
$id = $this->getInt('id');
if (!$id) throw new Am_Exception_InputError("Empty or no id passed");
$user = $this->getDi()->userTable->load($id);
$adapter = new Am_Auth_Adapter_User($user);
$this->getDi()->auth->login($adapter, $this->getRequest()->getClientIp(), false);
$this->_response->redirectLocation($this->getUrl('member', "index", null));
}
function accessLogAction()
{
require_once dirname(__FILE__) . '/AdminLogsController.php';
$c = new AdminLogsController($this->getRequest(), $this->getResponse(), $this->getInvokeArgs());
$grid = $c->createAccess();
$grid->removeField('member_login');
$grid->getDataSource()->addWhere('t.user_id=?d', (int)$this->getParam('user_id'));
$grid->runWithLayout('admin/user-layout.phtml');
}
function mailQueueAction()
{
require_once dirname(__FILE__) . '/AdminLogsController.php';
$c = new AdminLogsController($this->getRequest(), $this->getResponse(), $this->getInvokeArgs());
$grid = $c->createMailQueue();
$user = $this->getDi()->userTable->load($this->getParam('user_id'));
$grid->getDataSource()->addWhere('t.recipients LIKE ?', $user->email);
$grid->runWithLayout('admin/user-layout.phtml');
}
function notApprovedAction()
{
$this->_redirect('admin-users?_u_search[field-is_approved][val]=0');
}
function resendSignupEmailAction()
{
$id = $this->_request->getInt('id');
if (!$id) throw new Am_Exception_InputError("Empty id");
$user = $this->getDi()->userTable->load($id);
$user->sendSignupEmail();
$this->_response->ajaxResponse(array('success' => true));
}
}
PK \TuG G - default/controllers/AdminImportController.phpnu [ hasPermission(Am_Auth_Admin::PERM_IMPORT);
}
public function backAction()
{ // dummy - @see _runAction
}
public function preDispatch()
{
// Try to set any available english UTF-8 locale. Required for fgetcsv function to parse UTF-8 content.
setlocale(LC_ALL, 'C.UTF-8', 'en_US.UTF-8', 'C');
Am_Mail::setDefaultTransport(new Am_Mail_Transport_Null);
}
public function _runAction($action)
{
//handle back action here
//unset session variable for current step
//change action name
//go to process in normal way
if ($action == 'backAction') {
switch ($this->session->step) {
case 2 :
if (@$this->session->uploadSerialized) {
$this->upload->unserialize($this->session->uploadSerialized);
$this->upload->removeFiles();
}
unset($this->session->path);
unset($this->session->fieldsMap);
unset($this->session->importOptions);
$action = 'indexAction';
break;
case 3 :
unset($this->session->fieldsValue);
$action = 'assignAction';
break;
case 4 :
$action = 'defineAction';
break;
}
$this->getRequest()->setActionName(str_replace('Action', '', $action));
}
parent::_runAction($action);
}
public function init()
{
if (!$this->getDi()->uploadAcl->checkPermission('import',
Am_Upload_Acl::ACCESS_WRITE,
$this->getDi()->authAdmin->getUser())) {
throw new Am_Exception_AccessDenied();
}
$this->session = new Zend_Session_Namespace('amember_import');
$this->log = Import_Log::getInstance();
$this->upload = new Am_Upload($this->getDi());
$this->upload->setPrefix('import')->setTemp(3600);
if ($this->session->path) {
$this->dataSource = new Import_DataSource($this->session->path);
if (isset($this->session->importOptions['delim'])) {
$this->dataSource->setDelim($this->session->importOptions['delim']);
}
}
$this->addImportFields();
}
public function indexAction()
{
$this->cleanup();
if (!is_null($this->getParam('_h_p'))) {
print ($this->view->importHistory = $this->createDemoHistoryGrid()->render());
return;
}
$this->view->importHistory = $this->createDemoHistoryGrid()->render();
$this->session->step = 1;
$form = $this->getForm(self::FORM_UPLOAD);
if ($this->isPost()
&& $form->isSubmitted()
&& $this->upload->processSubmit('file')
&& $files = $this->upload->getUploads()) {
$file = $files[0];
$this->session->uploadSerialized = $this->upload->serialize();
$this->session->path = $file->getFullPath();
$this->dataSource = new Import_DataSource($this->session->path);
$this->assignAction();
} else {
$this->session->unsetAll();
$this->view->title = ___('Import: Step 1 of 4');
$this->view->form = $form;
$this->view->display('admin/import/index.phtml');
}
}
public function assignAction()
{
$this->session->step = 2;
$form = $this->getForm(self::FORM_ASSIGN);
$submited = $form->isSubmitted();
if ($submited) {
$this->session->importOptions['skip'] = $this->getParam('skip', 0);
$this->session->importOptions['add_subscription'] = $this->getParam('add_subscription', 0);
$this->session->importOptions['add_encrypted_pass'] = $this->getParam('add_encrypted_pass', 0);
$this->session->importOptions['encrypted_pass_format'] = $this->getParam('encrypted_pass_format');
$this->session->importOptions['delim'] = $this->getParam('delim');
if ($delimCode = $this->session->importOptions['delim']) {
$this->dataSource->setDelim($delimCode);
}
$this->session->fieldsMap = $this->getFieldsMapFromRequest();
//some import fields can be not applicable with new configuration
$this->clearImportFields();
$this->addImportFields();
//recreate form with new configuration
$form = $this->getForm(self::FORM_ASSIGN, $recreate = true, $force_submited = true);
}
if ($this->_request->isXmlHttpRequest()) {
echo $this->renderAssignTable();
exit;
}
if ($submited && !($error = $this->validateAssign())) {
$this->defineAction();
} else {
$table = $this->renderAssignTable();
if (isset($error) && $error) {
$this->view->error = $error;
}
$this->view->title = ___('Import: Step 2 of 4');
$this->view->table = $table;
$this->view->display('admin/import/assign.phtml');
}
}
protected function validateAssign()
{
$error = array();
$fildsToAssign = array();
foreach ($this->getImportFields(self::FIELD_TYPE_USER) as $field) {
if ($field->isRequired() && $field->isMustBeAssigned() && !$field->isAssigned()) {
$fildsToAssign[] = $field->getTitle();
}
}
if (isset($this->session->importOptions['add_subscription']) &&
1 == $this->session->importOptions['add_subscription']) {
foreach ($this->getImportFields(array(self::FIELD_TYPE_ACCESS, self::FIELD_TYPE_SUBSCRIPTION)) as $field) {
if ($field->isRequired() && $field->isMustBeAssigned() && !$field->isAssigned()) {
$fildsToAssign[] = $field->getTitle();
}
}
}
if (isset($this->session->importOptions['add_ecrypted_pass']) &&
1 == $this->session->importOptions['add_ecrypted_pass']) {
foreach ($this->getImportFields(self::FIELD_TYPE_ENCRYPTED_PASS) as $field) {
if ($field->isRequired() && $field->isMustBeAssigned() && !$field->isAssigned()) {
$fildsToAssign[] = $field->getTitle();
}
}
}
if (count($fildsToAssign)) {
$error[] = ___('Please assign the following fields: ') . implode(', ', $fildsToAssign);
}
//lets check if one field was assigned to more than one column
$fieldsDoubleAssigned = array();
$alreadyAssigned = array();
foreach ($this->getRequest()->getParams() as $key => $fieldId) {
if (strpos($key, 'FIELD') !== 0 || !$fieldId)
continue;
if (in_array($fieldId, $alreadyAssigned)) {
$field = $this->getImportField($fieldId);
if (!$field) {
$field = $this->getImportField($fieldId, self::FIELD_TYPE_ACCESS);
}
if (!$field) {
$field = $this->getImportField($fieldId, self::FIELD_TYPE_SUBSCRIPTION);
}
if (!$field) {
$field = $this->getImportField($fieldId, self::FIELD_TYPE_ENCRYPTED_PASS);
}
$fieldsDoubleAssigned[] = $field->getTitle();
} else {
array_push($alreadyAssigned, $fieldId);
}
}
if (count($fieldsDoubleAssigned)) {
$error[] = ___('One field can be assigned to one column only, you assigned following fields to several columns: ') . implode(', ', $fieldsDoubleAssigned);
}
return $error;
}
public function defineAction()
{
$this->session->step = 3;
$this->session->importOptions['skip_invoice'] = $this->getParam('_skip_invoice', 0);
$form = $this->getForm(self::FORM_DEFINE);
if ($form->isSubmitted()) {
$this->session->fieldsValue = $form->getValue();
}
$table = $this->renderPreviewTable();
if ($this->_request->isXmlHttpRequest()) {
echo $table . '
' . $form;
exit;
}
if ($form->isSubmitted() && $form->validate()) {
$this->confirmAction();
} else {
$this->view->title = ___('Import: Step 3 of 4');
$this->view->table = $table;
$this->view->form = $form;
$this->view->display('admin/import/define.phtml');
}
}
public function confirmAction()
{
$this->session->step = 4;
$form = $this->getForm(self::FORM_CONFIRM);
if ($form->isSubmitted()) {
$this->session->mode = $this->getParam('mode', self::MODE_SKIP);
$this->log->clearLog();
$this->importAction();
} else {
$this->view->title = ___('Import: Step 4 of 4');
$this->view->table = $this->renderPreviewTable();
$this->view->form = $form;
$this->view->display('admin/import/confirm.phtml');
}
}
public function doImport(& $context, $batch)
{
if ($lineParsed = $this->dataSource->getNextLineParsed()) {
$this->importLine($lineParsed);
$this->updateImportHistory();
return false;
}
return true;
}
public function importAction()
{
$this->getDi()->hook->toggleDisableAll(true);
$this->dataSource->setOffset($this->getStartOffset());
if (!$this->getStartOffset()) { //first chunk
$this->session->timeStart = time();
if ($this->session->importOptions['skip']) {
$this->dataSource->getNextLineParsed(); //skip first line;
}
if ($this->session->importOptions['add_encrypted_pass']) {
Am_Config::saveValue('allow_auth_by_savedpass', 1);
}
}
$batch = new Am_BatchProcessor(array($this, 'doImport'));
$context = null;
if (!$batch->run($context)) {
$this->sendRedirect();
}
$this->updateImportHistory(true);
if (@$this->session->uploadSerialized) {
$this->upload->unserialize($this->session->uploadSerialized);
$this->upload->removeFiles();
}
$this->reportAction();
}
public function reportAction()
{
$this->view->stat = $this->log->getStat();
$this->view->import_id = $this->getID();
$this->view->errors = $this->log->getErrors();
$this->view->skip = $this->log->getSkip();
$interval = time() - $this->session->timeStart;
$duration = array();
$duration['hrs'] = floor($interval / 3600);
$duration['min'] = floor(($interval - $duration['hrs'] * 3600) / 60);
$duration['sec'] = $interval - $duration['hrs'] * 3600 - $duration['min'] * 60;
$this->view->duration = sprintf("%02d:%02d:%02d", $duration['hrs'], $duration['min'], $duration['sec']
);
$this->view->display('admin/import/report.phtml');
$this->cleanup();
}
protected function cleanup()
{
if ($this->dataSource)
unset($this->dataSource);
$uploads = $this->upload->getUploads();
foreach ($uploads as $file) {
$file->delete();
}
$this->session->unsetAll();
}
public function deleteAction()
{
$this->session->unsetAll();
$this->session->proccessed = 0;
$this->session->lastUserId = 0;
$query = new Am_Query($this->getDi()->userTable);
$this->session->total = $query->getFoundRows();
$this->session->params = array();
$this->session->params['import-id'] = $this->getRequest()->getParam('id');
if (!$this->session->params['import-id']) {
throw new Am_Exception_InputError('import-id is undefined');
}
$this->sendDelRedirect();
}
function deleteUser(& $context, $batch)
{
$count = 10;
$query = new Am_Query($this->getDi()->userTable);
$query = $query->addOrder('user_id')->addWhere('user_id>?', $this->session->lastUserId);
$users = $query->selectPageRecords(0, $count);
$moreToProcess = false;
foreach ($users as $user) {
$importId = $user->data()->get('import-id');
$this->session->lastUserId = $user->pk();
if ($importId && $importId == $this->session->params['import-id']) {
$user->delete();
}
$this->session->proccessed++;
$moreToProcess = true;
}
return!$moreToProcess;
}
function doDeleteAction()
{
$batch = new Am_BatchProcessor(array($this, 'deleteUser'));
$context = null;
if (!$batch->run($context)) {
$this->sendDelRedirect();
}
$this->delImportHistory($this->session->params['import-id']);
$this->session->unsetAll();
$this->_redirect('admin-import');
}
function renderGridTitle($record)
{
return $record->completed ?
sprintf('%s | ',
___('You have imported %d customers',
$record->user_count)
) :
sprintf('%s | ',
___('Import of data was terminated while processing. Anyway some data was imported.')
);
}
public function createDemoHistoryGrid()
{
$records = $this->getDi()->store->getBlob('import-records');
$records = $records ? unserialize($records) : array();
$ds = new Am_Grid_DataSource_Array($records);
$ds->setOrder('date', true);
$grid = new Am_Grid_Editable('_h', ___('Import History'), $ds, $this->_request, $this->view);
$grid->setPermissionId(Am_Auth_Admin::PERM_IMPORT);
$grid->addField(new Am_Grid_Field_Date('date', ___('Date'), false, '', null, '10%'))
->setFormatDate();
$urlTpl = $this->getDi()->url('admin-users', array(
'_u_search' => array(
'import' => array(
'id' => '__ID__'
)
)
), false);
$urlTpl = str_replace('__ID__', '{id}', $urlTpl);
$grid->addField('id', '#', false, '', null, '10%')
->addDecorator(new Am_Grid_Field_Decorator_Link($urlTpl));
$grid->addField(new Am_Grid_Field('title', ___('Title'), false, '', array($this, 'renderGridTitle')));
$grid->actionsClear();
$grid->actionAdd(new Am_Grid_Action_ImportDel);
return $grid;
}
protected function sendDelRedirect()
{
$proccessed = $this->session->proccessed;
$total = $this->session->total;
$this->redirectHtml($this->getUrl('admin-import', 'do-delete'), ___('Clean up data. Please wait...'), ___('Clean up...'), false, $proccessed, $total);
}
protected function updateImportHistory($completed = false)
{
$records = $this->getDi()->store->getBlob('import-records');
$records = $records ? unserialize($records) : array();
$record = new stdClass();
$record->date = $this->getDi()->sqlDate;
$record->user_count = $this->log->getStat(Import_Log::TYPE_SUCCESS);
$record->id = $this->getID();
$record->can_be_canceled = ($this->session->mode == self::MODE_SKIP);
$record->completed = $completed;
$records[$this->getID()] = $record;
$this->getDi()->store->setBlob('import-records', serialize($records));
}
protected function delImportHistory($importId)
{
$records = $this->getDi()->store->getBlob('import-records');
$records = $records ? unserialize($records) : array();
unset($records[$importId]);
$this->getDi()->store->setBlob('import-records', serialize($records));
}
protected function sendRedirect()
{
$this->session->offset = $this->dataSource->getOffset();
$proccessed = $this->log->getStat(Import_Log::TYPE_PROCCESSED);
$total = $this->dataSource->getEstimateTotalLines($proccessed);
$this->redirectHtml($this->getUrl('admin-import', 'import'), ___('Import data. Please wait...'), ___('Import...'), false, $proccessed, $total);
}
protected function getID()
{
if (!$this->session->ID) {
$this->session->ID = sprintf('I-%s',
strtoupper($this->getDi()->security->randomString(6)));
}
return $this->session->ID;
}
protected function importLine($lineParsed)
{
$this->log->touchStat(Import_Log::TYPE_PROCCESSED);
$record = $this->createUserRecord($lineParsed);
$skip_user_fields = array();
$skip_add_encrypted_pass = false;
if ($record->isLoaded()) {
switch ($this->session->mode) {
case self::MODE_OVERWRITE :
$record->delete();
$record = $this->createUserRecord($lineParsed);
break;
case self::MODE_UPDATE :
break;
case self::MODE_UPDATE_LEAVE_PASSWORD :
$skip_user_fields = array('pass');
$skip_add_encrypted_pass = true;
break;
case self::MODE_SKIP :
$this->log->touchStat(Import_Log::TYPE_SKIP);
$this->log->logSkip($lineParsed);
return false;
default:
throw new Am_Exception_InternalError('Unknown mode [' . $this->mode . '] in class ' . __CLASS__);
}
}
foreach ($this->getImportFields(self::FIELD_TYPE_USER) as $field) {
if (in_array($field->getName(), $skip_user_fields)) continue;
$field->setValueForRecord($record, $lineParsed);
}
try {
$record->comment = "Imported (import #" . $this->getID() . ")";
$record->data()->set('import-id', $this->getID());
$record->data()->set('signup_email_sent', 1);
$record->save();
$this->log->touchStat(Import_Log::TYPE_SUCCESS);
if ($this->session->importOptions['add_subscription']) {
$this->addSub($record, $lineParsed);
$record->checkSubscriptions(true);
}
if ($this->session->importOptions['add_encrypted_pass'] && !$skip_add_encrypted_pass) {
$this->addEncryptedPass($record, $lineParsed, $this->session->importOptions['encrypted_pass_format']);
}
return $record->pk();
} catch (Exception $e) {
$this->log->touchStat(Import_Log::TYPE_ERROR);
$this->log->logError($e->getMessage(), $lineParsed);
return false;
}
}
protected function createUserRecord($lineParsed)
{
$record = null;
if (!$record) {
$loginField = $this->getImportField('login');
if ($login = $loginField->getValue($lineParsed)) {
$record = $this->getDi()->userTable->findFirstByLogin($login);
}
}
if (!$record) {
$emailField = $this->getImportField('email');
if ($email = $emailField->getValue($lineParsed)) {
$record = $this->getDi()->userTable->findFirstByEmail($email);
}
}
if (!$record) {
$record = $this->getDi()->userRecord;
}
return $record;
}
protected function addSub(Am_Record $user, $lineParsed)
{
$user_id = $user->pk();
$product = $this->getDi()->productTable->load(
$this->getImportField('product_id', self::FIELD_TYPE_ACCESS)->getValue($lineParsed),
false
);
if (!$product)
return;
if(!@$this->session->importOptions['skip_invoice'])
{
$invoice = $this->getDi()->invoiceRecord;
$invoice->tm_added =
$invoice->tm_started = $this->getImportField('begin_date', self::FIELD_TYPE_ACCESS)->getValue($lineParsed);
$invoice->user_id = $user_id;
$invoice->paysys_id = $this->getImportField('paysys_id', self::FIELD_TYPE_SUBSCRIPTION)->getValue($lineParsed);
$invoice->currency = Am_Currency::getDefault();
$invoice->add($product);
$items = $invoice->getItems();
$invoice->calculate();
$items[0]->first_price =
$items[0]->first_total =
$invoice->first_subtotal =
$invoice->first_total = $this->getImportField('amount', self::FIELD_TYPE_SUBSCRIPTION)->getValue($lineParsed);
$invoice->save();
if ($external_id = $this->getImportField('invoice_external_id', self::FIELD_TYPE_SUBSCRIPTION)->getValue($lineParsed))
$invoice->data()->set('external_id', $external_id)->update();
$payment = null;
if ($amount = $this->getImportField('amount', self::FIELD_TYPE_SUBSCRIPTION)->getValue($lineParsed)) {
$payment = $this->getDi()->invoicePaymentRecord;
$payment->amount = $amount;
$payment->user_id = $user_id;
$payment->paysys_id = $this->getImportField('paysys_id', self::FIELD_TYPE_SUBSCRIPTION)->getValue($lineParsed);
$payment->invoice_id = $invoice->pk();
$payment->receipt_id = $this->getImportField('receipt_id', self::FIELD_TYPE_SUBSCRIPTION)->getValue($lineParsed);
$payment->transaction_id = $this->getID();
$payment->currency = $invoice->currency;
$payment->dattm = $this->getImportField('begin_date', self::FIELD_TYPE_ACCESS)->getValue($lineParsed);
if (empty($payment->dattm)) {
$payment->dattm = $this->getDi()->sqlDateTime; // fallback to import time
}
$payment->save();
}
}
$access = $this->getDi()->accessRecord;
$access->begin_date = $this->getImportField('begin_date', self::FIELD_TYPE_ACCESS)->getValue($lineParsed);
$access->expire_date = $this->getImportField('expire_date', self::FIELD_TYPE_ACCESS)->getValue($lineParsed);
$access->user_id = $user_id;
$access->product_id = $product->pk();
$access->invoice_id = !empty($invoice) ? $invoice->pk() : null;
$access->invoice_payment_id = !empty($payment) ? $payment->pk() : null;
$access->transaction_id = $this->getID();
$access->save();
if(!@$this->session->importOptions['skip_invoice'])
{
$invoice->updateStatus();
if ($invoice->status == Invoice::RECURRING_ACTIVE)
$invoice->recalculateRebillDate();
}
}
protected function addEncryptedPass(Am_Record $user, $lineParsed, $format)
{
$user_id = $user->pk();
if ($format == SavedPassTable::PASSWORD_PHPASS) {
/* Special Case for Native aMember Hash Format */
$field = $this->getImportField('pass', self::FIELD_TYPE_ENCRYPTED_PASS);
$user->updateQuick('pass', $field->getValue($lineParsed));
} else {
$savedPass = $this->getDi()->savedPassTable->findFirstBy(array(
'user_id' => $user_id,
'format' => $format
));
if (!$savedPass) {
$savedPass = $this->getDi()->savedPassRecord;
$savedPass->format = $format;
$savedPass->user_id = $user_id;
}
foreach ($this->getImportFields(self::FIELD_TYPE_ENCRYPTED_PASS) as $field) {
$field->setValueForRecord($savedPass, $lineParsed);
}
$savedPass->save();
}
$user->data()->set(Am_Protect_Databased::USER_NEED_SETPASS, 1);
$user->save();
}
protected static function getImportModeOptions()
{
return array(
self::MODE_SKIP => ___('Skip Line if Exist User with Same Login'),
self::MODE_UPDATE => ___('Update User if Exist User with Same Login'),
self::MODE_UPDATE_LEAVE_PASSWORD => ___('Update User if Exist User with Same Login (Do Not Overwrite Existing Password)'),
self::MODE_OVERWRITE => ___('Overwrite User if Exist User with Same Login')
);
}
protected function getEncryptedPassFormatOptions()
{
$types = array(
SavedPassTable::PASSWORD_PHPASS => 'aMember',
SavedPassTable::PASSWORD_CRYPT => SavedPassTable::PASSWORD_CRYPT,
SavedPassTable::PASSWORD_MD5_MD5_PASS_SALT => SavedPassTable::PASSWORD_MD5_MD5_PASS_SALT
);
foreach ($this->getDi()->plugins_protect->loadEnabled()->getAllEnabled() as $pl) {
$format = $pl->getPasswordFormat();
if ($format === null)
continue;
$types[$format] = isset($types[$format]) ? $types[$format] . ', ' . $pl->getTitle() : $pl->getTitle();
}
return $types;
}
protected function getFieldsMapFromRequest()
{
$fieldsMap = array();
for ($i = 0; $i < $this->dataSource->getColNum(); $i++) {
$fieldName = $this->getParam('FIELD' . $i);
$fieldsMap[$fieldName] = $i;
}
return $fieldsMap;
}
protected function getRequestVarsFromFieldsMap()
{
$vars = array();
$fieldsMap = isset($this->session->fieldsMap) ? $this->session->fieldsMap : array();
foreach ($fieldsMap as $k => $v) {
$vars['FIELD' . $v] = $k;
}
return $vars;
}
protected function getRequestVarsFromImportOptions()
{
$result = array();
if (!isset($this->session->importOptions)) {
return $result;
}
$options = array('skip', 'add_subscription', 'add_encrypted_pass', 'encrypted_pass_format', 'delim');
foreach ($options as $opName) {
if (isset($this->session->importOptions[$opName])) {
$result[$opName] = $this->session->importOptions[$opName];
}
}
return $result;
}
protected function getRequestVarsFromFieldsValue()
{
if (!isset($this->session->fieldsValue)) {
return array();
} else {
return $this->session->fieldsValue;
}
}
protected function addImportField(Import_Field $field, $type = self::FIELD_TYPE_USER)
{
$field->setSession($this->session);
$field->setDi($this->getDi());
$this->importFields[$type][$field->getName()] = $field;
}
protected function getImportFields($type = self::FIELD_TYPE_USER)
{
if(!is_array($type))
$type = array($type);
$ret = array();
foreach($type as $key)
$ret+= $this->importFields[$key];
return $ret;
}
protected function getSubscriptionImportFields()
{
return $this->getImportFields(
(isset($this->session->importOptions['skip_invoice']) && $this->session->importOptions['skip_invoice']) ?
array(self::FIELD_TYPE_ACCESS) :
array(self::FIELD_TYPE_ACCESS, self::FIELD_TYPE_SUBSCRIPTION)
);
}
/**
* @param string $fieldName
* @param enum $type
* @return Import_Field
*/
protected function getImportField($fieldName, $type = self::FIELD_TYPE_USER)
{
return isset($this->importFields[$type][$fieldName]) ? $this->importFields[$type][$fieldName] : null;
}
protected function clearImportFields()
{
unset($this->importFields);
}
protected function addImportFields()
{
//User Fields
$this->addImportField(new Import_Field('email', ___('Email'), true));
if (!@$this->session->importOptions['add_encrypted_pass']) {
$this->addImportField(new Import_Field_UserPass('pass', 'Password', true));
}
$this->addImportField(new Import_Field('name_f', ___('First Name')));
$this->addImportField(new Import_Field('name_l', ___('Last Name')));
$this->addImportField(new Import_Field_UserLogin('login', ___('Username'), true));
$this->addImportField(new Import_Field_WithFixed('phone', ___('Phone')));
$this->addImportField(new Import_Field('street', ___('Street')));
$this->addImportField(new Import_Field('street2', ___('Street (Second Line)')));
$this->addImportField(new Import_Field('city', ___('City')));
$this->addImportField(new Import_Field_State('state', ___('State')));
$this->addImportField(new Import_Field_Country('country', ___('Country')));
$this->addImportField(new Import_Field('zip', ___('Zip Code')));
$this->addImportField(new Import_Field('tax_id', ___('VatId')));
$this->addImportField(new Import_Field('remote_addr', ___('User IP address')));
$this->addImportField(new Import_Field('comment', ___('Comment')));
$this->addImportField(new Import_Field('unsubscribed', ___('Is Unsubscribed? (0 - No, 1 - Yes)')));
$this->addImportField(new Import_Field('is_affiliate', ___('Is Affiliate? (0 - No, 1 - Yes)')));
$this->addImportField(new Import_Field('aff_id', ___('Affiliate Id')));
$this->addImportField(new Import_Field_Data('external_id', 'Member External ID'));
//Additional Fields
foreach ($this->getDi()->userTable->customFields()->getAll() as $field) {
if (isset($field->from_config) && $field->from_config) {
if ($field->sql) {
if ($field->type == 'date') {
$this->addImportField(new Import_Field_Date($field->name, $field->title));
} elseif(in_array($field->type, array('multi_select', 'checkbox'))) {
$this->addImportField(new Import_Field_Multiselect($field->name, $field->title));
} else {
$this->addImportField(new Import_Field($field->name, $field->title));
}
} else {
if ($field->type == 'date') {
$this->addImportField(new Import_Field_Data_Date($field->name, $field->title));
} elseif (in_array($field->type, array('multi_select', 'checkbox'))) {
$this->addImportField(new Import_Field_Data_Multiselect($field->name, $field->title));
} else {
$this->addImportField(new Import_Field_Data($field->name, $field->title));
}
}
}
}
//Subscription Fields
$this->addImportField(new Import_Field_SubProduct('product_id', ___('Subscription (Either ID or Title)'), true), self::FIELD_TYPE_ACCESS);
$this->addImportField(new Import_Field_SubPaysystem('paysys_id', ___('Paysystem'), true), self::FIELD_TYPE_SUBSCRIPTION);
$this->addImportField(new Import_Field_WithFixed('receipt_id', ___('Receipt'), true), self::FIELD_TYPE_SUBSCRIPTION);
$this->addImportField(new Import_Field_WithFixed('amount', ___('Payment Amount'), true), self::FIELD_TYPE_SUBSCRIPTION);
$this->addImportField(new Import_Field_Date('begin_date', ___('Subscription Begin Date'), true), self::FIELD_TYPE_ACCESS);
$this->addImportField(new Import_Field_Date('expire_date', ___('Subscription Expire Date'), true), self::FIELD_TYPE_ACCESS);
$this->addImportField(new Import_Field_Data('invoice_external_id', 'Invoice External ID'), self::FIELD_TYPE_SUBSCRIPTION);
//Encrypted Pass Fields
$this->addImportField(new Import_Field('pass', ___('Hash'), true), self::FIELD_TYPE_ENCRYPTED_PASS);
$this->addImportField(new Import_Field('salt', ___('Salt'), true), self::FIELD_TYPE_ENCRYPTED_PASS);
}
private function getStartOffset()
{
if (isset($this->session->offset)) {
return $this->session->offset;
} else {
return 0;
}
}
protected function getFieldOptions($type = self::FIELD_TYPE_USER)
{
$options = array();
foreach ($this->getImportFields($type) as $field) {
if ($field->isForAssign()) {
$options[$field->getName()] = $field->getTitle();
}
}
return $options;
}
protected function loadFieldsOptions($fSelect, $add_subscription=0, $add_encrypted_pass=0)
{
$fSelect->addOption('', '');
if ($add_subscription || $add_encrypted_pass) {
$optUser = $fSelect->addOptgroup(___('User'));
foreach ($this->getFieldOptions(self::FIELD_TYPE_USER) as $key => $value) {
$optUser->addOption($value, $key);
}
if ($add_subscription) {
$optSub = $fSelect->addOptgroup(___('Subscription'));
foreach ($this->getFieldOptions(array(self::FIELD_TYPE_ACCESS, self::FIELD_TYPE_SUBSCRIPTION)) as $key => $value) {
$optSub->addOption($value, $key);
}
}
if ($add_encrypted_pass) {
$optSub = $fSelect->addOptgroup(___('Encrypted Password'));
foreach ($this->getFieldOptions(self::FIELD_TYPE_ENCRYPTED_PASS) as $key => $value) {
$optSub->addOption($value, $key);
}
}
} else {
$fSelect->loadOptions(array('' => '') + $this->getFieldOptions());
}
}
private function getForm($name, $recreate = false, $force_submited = false)
{
$propertyName = $name . 'Form';
$methodName = 'create' . ucfirst($name) . 'Form';
if (!$this->$propertyName || $recreate) {
$this->$propertyName = $this->$methodName($force_submited);
}
return $this->$propertyName;
}
protected function createAssignForm($force_submited = false)
{
$form = new Am_Form_Admin('assign');
$form->setAction($this->getUrl(null, 'assign'));
$form->addElement('checkbox', 'skip')
->setLabel(___('Skip First Line'))
->setId('skip');
$form->addElement('checkbox', 'add_subscription')
->setLabel('' . ___('Add Subscription') . '')
->setId('add_subscription');
$form->addElement('checkbox', 'add_encrypted_pass')
->setLabel('' . ___('Import Encrypted Password') . '')
->setId('add_encrypted_pass');
$form->addElement('select', 'encrypted_pass_format')
->loadOptions($this->getEncryptedPassFormatOptions())
->setId('encrypted_pass_format');
$form->addElement('select', 'delim')
->setLabel(___('Delimiter'))
->loadOptions(Import_DataSource::getDelimOptions())
->setId('delim');
$form->addElement('submit', '_submit_', array('value' => ___('Next')))
->setId('_submit_');
for ($i = 0; $i < $this->dataSource->getColNum(); $i++) {
$fSelect = $form->addSelect('FIELD' . $i, array('class' => 'csv-fields'))
->setId('FIELD' . $i);
}
if ($force_submited || $form->isSubmitted()) {
$form->setDataSources(array(
$this->getRequest()
));
} else {
$form->setDataSources(array(
new HTML_QuickForm2_DataSource_Array(array(
'delim' => $this->dataSource->getDelim(Import_DataSource::DELIM_CODE)
) + $this->getRequestVarsFromFieldsMap()
+ $this->getRequestVarsFromImportOptions()
)
));
}
$formValues = $form->getValue();
$add_subscription = @$formValues['add_subscription'];
$add_encrypted_pass = @$formValues['add_encrypted_pass'];
for ($i = 0; $i < $this->dataSource->getColNum(); $i++) {
$fSelect = $form->getElementsByName('FIELD' . $i);
$this->loadFieldsOptions($fSelect[0], $add_subscription, $add_encrypted_pass);
}
return $form;
}
protected function createDefineForm($force_submited = false)
{
$form = new Am_Form_Admin('commit');
$form->setAction($this->getUrl(null, 'define'));
$fieldset = $form->addElement('fieldset', 'user')
->setLabel(___('User'));
foreach ($this->getImportFields() as $field) {
$field->buildForm($fieldset);
}
if ($this->session->importOptions['add_subscription']) {
$fieldset = $form->addElement('fieldset', 'subscription')
->setLabel(___('Subscription'));
$fieldset->addAdvCheckbox('_skip_invoice')->setLabel(___('Do not create invoice. Add only access record'));
foreach ($this->getSubscriptionImportFields() as $field) {
$field->buildForm($fieldset);
}
}
if ($this->session->importOptions['add_encrypted_pass']) {
$fieldset = $form->addElement('fieldset', 'encrypted_pass')
->setLabel(___('Encrypted Pass'));
foreach ($this->getImportFields(self::FIELD_TYPE_ENCRYPTED_PASS) as $field) {
$field->buildForm($fieldset);
}
}
$group = $form->addGroup();
$group->setSeparator(' ');
$group->addElement('inputbutton', 'back', array('value' => ___('Back')))
->setId('back');
$group->addElement('submit', '_submit_', array('value' => ___('Next')))
->setId('_submit_');
if ($force_submited || $form->isSubmitted()) {
$form->setDataSources(array($this->getRequest()));
} else {
$form->setDataSources(array(
new HTML_QuickForm2_DataSource_Array($this->getRequestVarsFromFieldsValue())
));
}
return $form;
}
protected function createConfirmForm($force_submited = false)
{
$form = new Am_Form_Admin('confirm');
$form->setAction($this->getUrl(null, 'confirm'));
$form->addAdvRadio('mode')
->setLabel(___('Import Mode'))
->loadOptions(self::getImportModeOptions())
->setValue(self::MODE_SKIP);
$group = $form->addGroup();
$group->setSeparator(' ');
$group->addElement('inputbutton', 'back', array('value' => ___('Back')))
->setId('back');
$group->addElement('submit', '_submit_', array('value' => ___('Do Import')))
->setId('_submit_');
if ($force_submited || $form->isSubmitted()) {
$form->setDataSources(array($this->getRequest()));
} else {
$form->setDataSources(array(new HTML_QuickForm2_DataSource_Array(array())));
}
return $form;
}
protected function createUploadForm($force_submited = false)
{
$form = new Am_Form_Admin('upload');
$form->setAction($this->getUrl(null, ''));
$form->setAttribute('enctype', 'multipart/form-data');
$file = $form->addElement('file', 'file[]')
->setLabel(___('File'));
$file->setAttribute('class', 'styled');
$file->addRule('required', ___('This field is a requried field'));
$form->addElement('submit', '_submit_', array('value' => ___('Next')));
return $form;
}
protected function getAssignFormRendered()
{
$form = $this->getForm(self::FORM_ASSIGN);
$renderer = HTML_QuickForm2_Renderer::factory('array');
$form->render($renderer);
$form = $renderer->toArray();
$elements = array();
foreach ($form['elements'] as $element) {
$elements[$element['id']] = $element;
}
$form['elements'] = $elements;
return $form;
}
protected function renderAssignTable()
{
$form = $this->getAssignFormRendered();
$linesParsed = $this->dataSource->getFirstLinesParsed(10);
if (!count($linesParsed)) {
return sprintf('',
___('No one line found in the file. It looks like file is empty. You can go back and try another file.'));
}
$out = sprintf('';
return $out;
}
protected function renderPreviewTable()
{
$out = '';
$out .= '
';
$out .= ' | ';
$importFields = $this->getImportFields();
foreach ($importFields as $field) {
if ($field->isForImport()) {
$out .= sprintf('%s', ($field->isRequired() && !$field->isDefined()) ? ' class="required"' : '', $field->getTitle()
);
}
}
if ($this->session->importOptions['add_subscription']) {
$importSubFields = $this->getSubscriptionImportFields();
foreach ($importSubFields as $field) {
if ($field->isForImport()) {
$out .= sprintf('%s', ($field->isRequired() && !$field->isDefined()) ? ' class="required"' : '', $field->getTitle()
);
}
}
}
if ($this->session->importOptions['add_encrypted_pass']) {
$importEncryptedFields = $this->getImportFields(self::FIELD_TYPE_ENCRYPTED_PASS);
foreach ($importEncryptedFields as $field) {
if ($field->isForImport()) {
$out .= sprintf('%s', ($field->isRequired() && !$field->isDefined()) ? ' class="required"' : '', $field->getTitle()
);
}
}
}
$out .= '
|---|
';
$linesParsed = $this->dataSource->getFirstLinesParsed(10);
if ($this->session->importOptions['skip']) {
unset($linesParsed[0]);
}
foreach ($linesParsed as $lineNum => $lineParsed) {
$out .= '| ' . $lineNum . ' | ';
$dummyUser = $this->getDi()->userRecord;
foreach ($importFields as $field) {
if ($field->isForImport()) {
$field->setValueForRecord($dummyUser, $lineParsed);
$out .= sprintf('%s | ', $field->getReadableValue($lineParsed, $dummyUser));
}
}
if ($this->session->importOptions['add_subscription']) {
$importSubFields = $this->getSubscriptionImportFields();
foreach ($importSubFields as $field) {
if ($field->isForImport()) {
$out .= sprintf('%s | ', $field->getReadableValue($lineParsed));
}
}
}
if ($this->session->importOptions['add_encrypted_pass']) {
$importPassFields = $this->getImportFields(self::FIELD_TYPE_ENCRYPTED_PASS);
foreach ($importPassFields as $field) {
if ($field->isForImport()) {
$out .= sprintf('%s | ', $field->getReadableValue($lineParsed));
}
}
}
$out .= '
';
}
$out .= '
';
$out .= '
%s
", ___('Generated')));
}
public function getValue($lineParsed, $partialRecord = null)
{
/* @var $partialRecord User */
if ($this->isAssigned()) {
return parent::getValue($lineParsed, $partialRecord);
} else {
if ($partialRecord) {
$partialRecord->generateLogin();
return $partialRecord->login;
} else {
return $this->getDi()->security->randomString(8);
}
}
}
public function setValueForRecord($record, $lineParsed)
{
//user already exists in database and found by email address
//so we do not want to overwrite his login with autogenerated value but we
//still use new value for login if it is fetched from file
if (!$this->isAssigned() && @$record->login)
return;
parent::setValueForRecord($record, $lineParsed);
}
}
class Import_DataSource
{
const MAX_LINE_LENGTH = 4096;
const DELIM_SEMICOLON = 1;
const DELIM_COMMA = 2;
const DELIM_SPACE = 3;
const DELIM_TABULATION = 4;
const DELIM_VALUE = 1;
const DELIM_CODE = 2;
protected $filePointerIterator = null;
protected $filePointer = null;
protected $colNum = null;
protected $delimCode = null;
protected $firstLineRaw = null;
protected $firstLineParsed = null;
public function __construct($path)
{
$this->filePointer = fopen($path, 'r');
$this->filePointerIterator = fopen($path, 'r');
}
public function __destruct()
{
fclose($this->filePointer);
fclose($this->filePointerIterator);
}
public function getOffset()
{
return ftell($this->filePointerIterator);
}
public function setOffset($offset = 0)
{
fseek($this->filePointerIterator, $offset);
}
public function rewind()
{
$this->setOffset(0);
}
public function getDelim($mode = self::DELIM_VALUE)
{
if (is_null($this->delimCode)) {
$this->delimCode = $this->guessDelim();
}
switch ($mode) {
case self::DELIM_VALUE :
return self::getDelimByCode($this->delimCode);
case self::DELIM_CODE :
return $this->delimCode;
default :
throw new Am_Exception_InputError(
___('Unknown mode [%s] in %s->%s', $mode, __CLASS__, __METHOD__));
}
}
public function setDelim($delimCode)
{
$this->delimCode = $delimCode;
//remove cached values that depends on delimiter
$this->colNum = null;
$this->firstLineParsed = null;
}
public function getNextLineParsed($pointer=null, $normalize = true)
{
$pointer = $pointer ? $pointer : $this->filePointerIterator;
$res = $this->_getNextLineParsed($pointer);
if ($res === false || !is_array($res))
return false;
if (is_null($res[0]))
return $this->getNextLineParsed($pointer, $normalize);
return $normalize ? $this->normalizeLineParsed($res) : $res;
}
protected function _getNextLineParsed($pointer)
{
if (feof($pointer)) {
return false;
} else {
return fgetcsv($pointer, self::MAX_LINE_LENGTH, $this->getDelim());
}
}
public function getFirstLineParsed($normalize = true)
{
if (!$this->firstLineParsed) {
fseek($this->filePointer, 0);
$this->firstLineParsed = $this->getNextLineParsed($this->filePointer, $normalize);
}
return $this->firstLineParsed;
}
public function getFirstLinesParsed($num, $normalize = true)
{
$result = array();
fseek($this->filePointer, 0);
for ($i = 0; $i < $num; $i++) {
$res = $this->getNextLineParsed($this->filePointer, $normalize);
if (!$res) {
break;
}
$result[$i] = $res;
}
return $result;
}
public function getColNum()
{
if (!$this->colNum) {
$this->colNum = count((array) $this->getFirstLineParsed(false));
}
return $this->colNum;
}
public static function getDelimOptions()
{
return array(
self::DELIM_SEMICOLON => ___('Semicolon'),
self::DELIM_COMMA => ___('Comma'),
self::DELIM_SPACE => ___('Space'),
self::DELIM_TABULATION => ___('Tabulation')
);
}
public function getEstimateTotalLines($proccessed)
{
$perLine = round($this->getOffset() / $proccessed);
$total = round($this->getFileSize() / $perLine);
return $total;
}
protected function getFirstLineRaw()
{
if (!$this->firstLineRaw) {
fseek($this->filePointer, 0);
$this->firstLineRaw = trim(fgets($this->filePointer));
}
return $this->firstLineRaw;
}
private function getFileSize()
{
$stat = fstat($this->filePointer);
return $stat['size'];
}
protected function normalizeLineParsed($lineParsed)
{
$result = (array) $lineParsed;
if (count($lineParsed) > $this->getColNum()) {
$result = array_slice($result, 0, $this->getColNum());
} elseif (count($lineParsed) < $this->getColNum()) {
$result = array_pad($result, $this->getColNum(), '');
}
return $result;
}
protected static function getDelimMap()
{
return array(
self::DELIM_SEMICOLON => ';',
self::DELIM_COMMA => ',',
self::DELIM_SPACE => ' ',
self::DELIM_TABULATION => "\t"
);
}
protected static function getDelimByCode($delimCode)
{
$map = self::getDelimMap();
if (!isset($map[$delimCode])) {
throw new Am_Exception_InputError('Unknown delim code [' . $delimCode . ']');
}
return $map[$delimCode];
}
protected function guessDelim()
{
foreach (self::getDelimMap() as $delimCode => $delim) {
if (count(explode($delim, $this->getFirstLineRaw())) >= 3) {
return $delimCode;
}
}
return self::DELIM_SEMICOLON;
}
}
class Import_Log
{
const TYPE_SKIP = 1;
const TYPE_ERROR = 2;
const TYPE_SUCCESS = 3;
const TYPE_PROCCESSED = 4;
const MAX_ERRORS_LOG = 15;
const MAX_SKIP_LOG = 15;
/** @var Zend_Session_Namespace */
protected $session;
protected static $instance = null;
protected function __construct()
{
$this->session = new Zend_Session_Namespace('amember_import_log');
}
public static function getInstance()
{
if (!self::$instance) {
self::$instance = new self();
}
return self::$instance;
}
public function touchStat($type)
{
if (!isset($this->session->stat) ||
!is_array($this->session->stat)) {
$this->session->stat = array(
self::TYPE_SKIP => 0,
self::TYPE_ERROR => 0,
self::TYPE_SUCCESS => 0,
self::TYPE_PROCCESSED => 0
);
}
$this->session->stat[$type]++;
}
public function getStat($type = null)
{
if (is_null($type)) {
return $this->session->stat;
}
if (isset($this->session->stat[$type])) {
return $this->session->stat[$type];
} else {
return 0;
}
}
public function logError($message, $lineParsed)
{
if (!isset($this->session->errors)) {
$this->session->errors = array();
}
if (count($this->session->errors) >= self::MAX_ERRORS_LOG) {
return;
}
$error = array();
$error['msg'] = $message;
$error['lineParsed'] = $lineParsed;
$this->session->errors[] = $error;
}
public function logSkip($lineParsed)
{
if (!isset($this->session->skip)) {
$this->session->skip = array();
}
if (count($this->session->skip) >= self::MAX_SKIP_LOG) {
return;
}
$this->session->skip[] = $lineParsed;
}
public function clearLog()
{
$this->session->errors = array();
$this->session->skip = array();
$this->session->stat = null;
}
public function getErrors()
{
if (!isset($this->session->errors)) {
$this->session->errors = array();
}
return $this->session->errors;
}
public function getSkip()
{
if (!isset($this->session->skip)) {
$this->session->skip = array();
}
return $this->session->skip;
}
}
class Am_Grid_Action_ImportDel extends Am_Grid_Action_Abstract
{
protected $title = 'Delete';
protected $id = "delete";
public function __construct()
{
parent::__construct();
$this->setTarget('_top');
}
public function run()
{
//nop
}
public function getUrl($record = null, $id = null)
{
return $this->grid->getDi()->url('admin-import/delete',array('id' => $record->id), false);
}
public function isAvailable($record)
{
return $record->can_be_canceled;
}
}
PK \"b&7 7 0 default/controllers/AdminSavedFormController.phpnu [ grid->getRecord();
$record->generateCode();
$vars = $record->toRow();
unset($vars['saved_form_id']);
unset($vars['default_for']);
$vars['title'] = ___('Copy of') . ' ' . $record->title;
$back = @$_SERVER['HTTP_X_REQUESTED_WITH'];
$_SERVER['HTTP_X_REQUESTED_WITH'] = 'XMLHttpRequest';
$request = new Am_Mvc_Request($vars + array($this->grid->getId() . '_a' => 'insert-' . $record->type,
$this->grid->getId() . '_b' => $this->grid->getBackUrl()), Am_Mvc_Request::METHOD_POST);
$controller = new AdminSavedFormController($request, new Am_Mvc_Response(),
array('di' => Am_Di::getInstance()));
$request->setModuleName('default')
->setControllerName('admin-saved-form')
->setActionName('index')
->setDispatched(true);
$controller->dispatch('indexAction');
$response = $controller->getResponse();
$response->sendResponse();
$_SERVER['HTTP_X_REQUESTED_WITH'] = $back;
}
}
class Am_Grid_Action_Sort_SavedForm extends Am_Grid_Action_Sort_Abstract
{
protected function setSortBetween($item, $after, $before)
{
$this->_simpleSort(Am_Di::getInstance()->savedFormTable, $item, $after, $before);
}
}
class Am_Form_Admin_SavedForm extends Am_Form_Admin
{
/** @var SavedForm */
protected $record;
/** @var Am_Form_Element_BricksEditor */
protected $brickEditor;
public function __construct(SavedForm $record)
{
$this->record = $record;
parent::__construct();
}
public function init()
{
parent::init();
$typeDef = $this->record->getTypeDef();
$type = $this->addSelect('type', null, array('options' => Am_Di::getInstance()->savedFormTable->getTypeOptions()));
$type->setLabel(___('Form Type'));
if (!empty($this->record->type)) $type->toggleFrozen(true);
$title = $this->addText('title', array('class' => 'el-wide'))->setLabel(
___("Custom Signup Form Title\n".
"keep empty to use default title"));
$comment = $this->addText('comment', array('class' => 'el-wide'))
->setLabel(
___("Comment\nfor admin reference"));
if ($this->record->isSignup() || $this->record->isProfile())
{
if (!empty($typeDef['generateCode'])) {
$code = $this->addText('code')
->setLabel(___("Secret Code\n".
"if form is not choosen as default, this code\n".
"(inside URL) will be necessary to open form"))
->addRule('regex', ___('Value must be alpha-numeric'), '/[a-zA-Z0-9_]/');
}
}
if ($this->record->type == SavedForm::T_SIGNUP || $this->record->type == SavedForm::T_PROFILE) {
$this->addAdvCheckbox('hide')
->setLabel(___("Hide from Menu\n" .
"do not include link to this form in members menu"));
}
$this->brickEditor = $this->addElement(new Am_Form_Element_BricksEditor('fields', array(), $this->record->createForm()))
->setLabel(___('Fields'));
if ($this->record->isSignup()) {
$this->addSelect('tpl')
->setLabel(___("Template\nalternative template for signup page").
"\n" .
___("aMember will look for templates in [application/default/views/signup/] folder\n".
"and in theme's [signup/] folder\n".
"and template filename must start with [signup]"))
->loadOptions($this->getSignupTemplates());
}
$fs = $this->addAdvFieldset('meta', array('id'=>'meta'))
->setLabel(___('Meta Data'));
$fs->addText('meta_title', array('class' => 'el-wide'))
->setLabel(___('Title'));
$fs->addText('meta_keywords', array('class' => 'el-wide'))
->setLabel(___('Keywords'));
$fs->addText('meta_description', array('class' => 'el-wide'))
->setLabel(___('Description'));
$gr = $fs->addGroup()->setLabel(___("Robots\n" .
"instructions for search engines"));
$gr->setSeparator(' ');
$gr->addCheckbox('meta_robots[]', array('value' => 'noindex'), array('content' => 'noindex'));
$gr->addCheckbox('meta_robots[]', array('value' => 'nofollow'), array('content' => 'nofollow'));
$gr->addCheckbox('meta_robots[]', array('value' => 'noarchive'), array('content' => 'noarchive'));
$gr->addFilter('array_filter');
}
public function render(HTML_QuickForm2_Renderer $renderer)
{
return parent::render($renderer);
}
static function getSignupTemplates()
{
$folders = array(
AM_APPLICATION_PATH . '/default/views/' => 1,
AM_APPLICATION_PATH . '/default/themes/' . Am_Di::getInstance()->config->get('theme') => 2,
);
if(Am_Di::getInstance()->config->get('protect.wordpress.use_wordpress_theme'))
{
$path = defined("TEMPLATEPATH") ? TEMPLATEPATH : 'default';
$path_parts = preg_split('/[\/\\\]/', $path);
$path = array_pop($path_parts);
if (file_exists(AM_APPLICATION_PATH . '/default/plugins/protect/wordpress/' . $path))
{
$path = $path;
}
else if (preg_match("/^([a-zA-Z]+)/", $path, $regs) && file_exists(AM_APPLICATION_PATH . '/default/plugins/protect/wordpress/' . $regs[1]))
{
$path = $regs[1];
}
else
{
$path = false;
}
if($path)
$folders[AM_APPLICATION_PATH . '/default/plugins/protect/wordpress/' . $path] = 3;
}
$ret = array();
foreach (array_keys($folders) as $f)
{
foreach ((array)glob($f . '/signup/signup*.phtml') as $file)
{
if (!strlen($file)) continue;
$file = basename($file);
$ret[$file == 'signup.phtml' ? null : $file] = $file;
}
}
return $ret;
}
public function renderEpilog()
{
return $this->brickEditor->renderConfigForms();
}
}
class AdminSavedFormController extends Am_Mvc_Controller_Grid
{
public function checkAdminPermissions(Admin $admin)
{
return $admin->hasPermission(Am_Auth_Admin::PERM_FORM);
}
function init()
{
if (!class_exists('Am_Form_Brick', false)) {
class_exists('Am_Form_Brick', true);
Am_Di::getInstance()->hook->call(Am_Event::LOAD_BRICKS);
}
parent::init();
}
public function createGrid()
{
$this->view->headScript()->appendFile($this->view->_scriptJs("jquery/jquery.json.js"));
$table = $this->getDi()->savedFormTable;
$ds = new Am_Query($table);
$ds->addWhere('`type` in (?a)', array_keys($table->getTypeDefs()));
$ds->addOrderRaw("sort_order");
$grid = new Am_Grid_Editable('_s', ___('Forms Editor'), $ds, $this->_request, $this->view);
$grid->setPermissionId(Am_Auth_Admin::PERM_FORM);
$grid->setEventId('gridSavedForm');
$grid->setForm(array($this, 'createForm'));
$grid->setRecordTitle(' ');
$grid->addField(SavedForm::D_SIGNUP, ___('Default Signup'), false)
->setWidth('5%')
->setRenderFunction(array($this, 'renderSignupDefault'));
$grid->addField(SavedForm::D_MEMBER, ___('Default for Members'), false)
->setWidth('5%')
->setRenderFunction(array($this, 'renderSignupDefault'));
$grid->addField(SavedForm::D_PROFILE, ___('Default for Profile'), false)
->setWidth('5%')
->setRenderFunction(array($this, 'renderProfileDefault'));
$grid->addField('hide', ___('Hide'));
$existingTypes = $this->getDi()->savedFormTable->getExistingTypes();
$grid->actionGet('edit')->setTarget('_top');
$grid->actionDelete('insert');
foreach ($this->getDi()->savedFormTable->getTypeDefs() as $type => $typeDef)
{
if (!empty($typeDef['isSingle']) && in_array($type, $existingTypes))
continue;
$grid->actionAdd(new Am_Grid_Action_Insert('insert-'.$type))
->addUrlParam('type', $type)->setTitle(___('New %s', $typeDef['title']));
}
$grid->addCallback(Am_Grid_Editable::CB_BEFORE_SAVE, array($this, 'beforeSave'));
$grid->addField(new Am_Grid_Field('type', ___('Type')));
$grid->addField(new Am_Grid_Field('title', ___('Title')));
$grid->addField(new Am_Grid_Field('comment', ___('Comment')));
$grid->addField(new Am_Grid_Field('url', ___('URL'), false))
->setRenderFunction(array($this, 'renderUrl'));
$grid->actionGet('delete')
->setIsAvailableCallback(function($r) {return $r->canDelete();});
$grid->actionAdd(new Am_Grid_Action_CopySavedForm())
->setIsAvailableCallback(function($r) {return !$r->isSingle();});
$grid->setFormValueCallback('meta_robots', array('RECORD', 'unserializeList'), array('RECORD', 'serializeList'));
$grid->addCallback(Am_Grid_ReadOnly::CB_RENDER_STATIC, function(& $out, $grid) {
$out .= <<
jQuery('.grid-wrap').on('change', 'input.set-default', function(){
jQuery(this).closest("form").submit();
});
CUT;
});
$grid->actionAdd(new Am_Grid_Action_LiveCheckbox('hide'))
->setIsAvailableCallback(function($r) {
return $r->type == SavedForm::T_SIGNUP || $r->type == SavedForm::T_PROFILE;
});
$grid->actionAdd(new Am_Grid_Action_Sort_SavedForm);
$grid->setFilter(new Am_Grid_Filter_Text(___('Title/Comment/Code'), array(
'title' => 'LIKE',
'comment' => 'LIKE',
'code' => 'LIKE'
)));
return $grid;
}
public function beforeSave(array & $values)
{
$fields = json_decode($values['fields'],true);
foreach($fields as &$f)
if(isset($f['labels']))
foreach($f['labels'] as $k=>$l)
$f['labels'][$k] = preg_replace("/\r\n/","\n",$l);
$values['fields'] = json_encode($fields);
if (($values['type'] == 'signup') && !strlen($values['code']))
{
$values['code'] = $this->getDi()->security->randomString(8);
}
}
public function renderDefault(SavedForm $record, $field, $type)
{
$html = "";
if ($record->type == $type)
{
$checked = $record->isDefault($field) ? "checked='checked'" : "";
$html = sprintf('
',
$this->getDi()->url('admin-saved-form/set-default'),
$field, $record->saved_form_id,
$checked);
}
return $this->renderTd($html, false);
}
public function renderSignupDefault(SavedForm $record, $field)
{
return $this->renderDefault($record, $field, SavedForm::T_SIGNUP);
}
public function renderProfileDefault(SavedForm $record, $field)
{
return $this->renderDefault($record, $field, SavedForm::T_PROFILE);
}
public function setDefaultAction()
{
foreach ($this->getRequest()->getPost('default') as $d => $id)
$this->getDi()->savedFormTable->setDefault($d, $id);
$this->_redirect('admin-saved-form');
}
public function createForm()
{
$record = $this->grid->getRecord();
$post = $this->grid->getCompleteRequest()->getPost();
if (!$record->isLoaded())
{
if ($type = $this->_request->getFiltered('type'))
$record->type = $type;
if ($record->type && empty($post['type'])) // form was not submitted yet
$record->setDefaults();
}
$form = new Am_Form_Admin_SavedForm($record);
$form->addRule('callback', '-error-', array($this, 'validate'));
return $form;
}
public function renderUrl(SavedForm $record)
{
$content = sprintf('%s',
$record->getUrl(ROOT_URL . '/'), $record->getUrl(""));
return $this->renderTd($content, false);
}
function validate(array $value)
{
/// check for unique code
$el = $this->grid->getForm()->getElementById('code-0');
if ($el && strlen($code = $el->getValue()))
{
if ($id = $this->getDi()->db->selectCell("SELECT saved_form_id
FROM ?_saved_form
WHERE code=? AND saved_form_id<>?d AND type=?",
$code,
(int)@$value['_s_id'],
$value['type']))
{
$code = $this->escape($code);
$el->setError(___('The code [%s] is already used by signup form #%s, please choose another code', $code, $id));
return false;
}
}
return true;
}
}PK \lI:: : ( default/controllers/SignupController.phpnu [ hook->call(Am_Event::LOAD_BRICKS);
}
parent::init();
}
function loadForm()
{
if ($c = $this->getFiltered('c')) {
if ($c == 'cart') {
if ($this->_request->getParam('amember_redirect_url'))
$this->getSession()->redirectUrl = $this->_request->getParam('amember_redirect_url');
if($this->getDi()->auth->getUser() != null) {
$url = $this->getSession()->redirectUrl;
$this->getSession()->redirectUrl = '';
$this->_redirect($url);
} else {
$this->record = $this->getDi()->savedFormTable->getByType(SavedForm::T_CART);
}
} else {
$this->record = $this->getDi()->savedFormTable->findFirstBy(array(
'code' => $c,
'type' => SavedForm::T_SIGNUP,
));
}
} else {
$this->record = $this->getDi()->savedFormTable->getDefault
(
$this->getDi()->auth->getUserId() ?
SavedForm::D_MEMBER : SavedForm::D_SIGNUP
);
}
// call a hook to allow load another form
$event = new Am_Event(Am_Event::LOAD_SIGNUP_FORM, array(
'request' => $this->_request,
'user' => $this->getDi()->auth->getUser(),
));
$event->setReturn($this->record);
$this->getDi()->hook->call($event);
$this->record = $event->getReturn();
if (!$this->record) {
$this->getDi()->errorLogTable->log("Wrong signup form code - the form does not exists. Redirect Customer to default form. Referrer: " . $this->getRequest()->getHeader('REFERER'));
$this->redirect('/signup', array('code'=>302));
}
/* @var $this->record SavedForm */
if (!$this->record->isSignup())
throw new Am_Exception_InputError("Wrong signup form loaded [$this->record->saved_form_id] - it is not a signup form!");
if ($this->record->meta_title)
$this->view->meta_title = $this->record->meta_title;
if ($this->record->meta_keywords)
$this->view->headMeta()->setName('keywords', $this->record->meta_keywords);
if ($this->record->meta_description)
$this->view->headMeta()->setName('description', $this->record->meta_description);
if ($this->record->meta_robots)
$this->view->headMeta()->setName('robots', $this->record->meta_robots);
$this->view->code = $this->record->code;
$this->view->record = $this->record;
}
function indexAction()
{
/*
* First check user's login. user can be logged in plugin or user's login info can be in cookies.
* Result does not matter here so skip it;
*/
if(!$this->getDi()->auth->getUserId() && $this->_request->isGet())
$this->getDi()->auth->checkExternalLogin($this->_request);
/*==TRIAL_SPLASH==*/
if (!$this->getDi()->auth->getUserId() && $this->getDi()->config->get('signup_disable')) {
$e = new Am_Exception_InputError(___('New Signups are Disabled'));
$e->setLogError(false);
throw $e;
}
$this->loadForm();
$this->view->title = $this->record->title;
$this->form = new Am_Form_Signup();
$this->form->setParentController($this);
$this->form->initFromSavedForm($this->record);
try {
$this->form->run();
} catch (Am_Exception_QuietError $e){
$e->setPublicTitle($this->record->title);
throw $e;
}
}
function display(Am_Form $form, $pageTitle)
{
$this->view->form = $form;
$this->view->title = $pageTitle ?: $this->record->title;
$this->view->display($this->record->tpl ? ('signup/' . basename($this->record->tpl)) : 'signup/signup.phtml');
}
function autoLoginIfNecessary()
{
if (($this->getConfig('auto_login_after_signup') || ($this->record->type == SavedForm::T_CART)) && $this->user->isApproved())
{
$this->user->refresh();
$adapter = new Am_Auth_Adapter_User($this->user);
$this->getDi()->auth->login($adapter, $this->getRequest()->getClientIp(), false);
}
}
function process(array $vars, $name, HTML_QuickForm2_Controller_Page $page)
{
$this->getDi()->hook->call(Am_Event::SIGNUP_PAGE_BEFORE_PROCESS, array(
'vars' => $vars,
'savedForm' => $this->record
));
$this->vars = $vars;
// do actions here
$this->user = $this->getDi()->auth->getUser();
if ($this->getSession()->signup_member_id && $this->getSession()->signup_member_login)
{
$user = $this->getDi()->userTable->load((int)$this->getSession()->signup_member_id, false);
if ($user && ((($this->getDi()->time - strtotime($user->added)) < 24*3600) && ($user->status == User::STATUS_PENDING)))
{
// prevent attacks as if someone has got ability to set signup_member_id to session
if ($this->getSession()->signup_member_login == $user->login) {
/// there is a potential problem
/// because user password is not updated second time - @todo
$this->user = $user;
$this->autoLoginIfNecessary();
} else {
$this->getSession()->signup_member_id = null;
$this->getSession()->signup_member_login = null;
}
} else {
$this->getSession()->signup_member_id = null;
}
}
$event = new Am_Event(Am_Event::SIGNUP_LOAD_USER, array(
'vars' => $vars,
'savedForm' => $this->record
));
$event->setReturn($this->user);
$this->getDi()->hook->call($event);
$this->user = $event->getReturn();
if (!$this->user)
{
$this->user = $this->getDi()->userRecord;
$this->user->setForInsert($this->vars); // vars are filtered by the form !
if (empty($this->user->login))
$this->user->generateLogin();
if (empty($this->vars['pass'])) {
$this->user->generatePassword();
} else {
$this->user->setPass($this->vars['pass']);
}
if (empty($this->user->lang))
$this->user->lang = $this->getDi()->locale->getLanguage();
$this->user->saved_form_id = $this->record->pk();
$this->user->insert();
$this->getSession()->signup_member_id = $this->user->pk();
$this->getSession()->signup_member_login = $this->user->login;
$this->autoLoginIfNecessary();
// user inserted
$this->getDi()->hook->call(Am_Event::SIGNUP_USER_ADDED, array(
'vars' => $this->vars,
'user' => $this->user,
'form' => $this->form,
'savedForm' => $this->record
));
if ($this->getDi()->config->get('registration_mail'))
$this->user->sendRegistrationEmail();
if ($this->getDi()->config->get('registration_mail_admin'))
$this->user->sendRegistrationToAdminEmail();
if(!$this->user->isApproved())
$this->user->sendNotApprovedEmail();
} else {
if ($this->record->isCart()) {
$url = $this->getSession()->redirectUrl;
$this->getSession()->redirectUrl = '';
$this->_redirect($url ? urldecode($url) : $this->getDi()->url('cart',null,false), array('prependBase' => false));
}
unset($this->vars['pass']);
unset($this->vars['login']);
unset($this->vars['email']);
$this->user->setForUpdate($this->vars)->update();
// user updated
$this->getDi()->hook->call(Am_Event::SIGNUP_USER_UPDATED, array(
'vars' => $this->vars,
'user' => $this->user,
'form' => $this->form,
'savedForm' => $this->record
));
}
// keep reference to e-mail confirmation link so it still working after signup
if (!empty($this->vars['code']))
{
$this->getDi()->store->setBlob(Am_Form_Signup_Action_SendEmailCode::STORE_PREFIX . $this->vars['code'],
$this->user->pk(), '+7 days');
}
if ($this->record->isCart())
{
$url = $this->getSession()->redirectUrl;
$this->getSession()->redirectUrl = '';
$this->_redirect($url ? urldecode($url) : $this->getDi()->url('cart',null,false), array('prependBase' => false));
return true;
}
/// now the ordering process
$invoice = $this->getDi()->invoiceRecord;
$invoice->saved_form_id = $this->record->pk();
$this->getDi()->hook->call(Am_Event::INVOICE_SIGNUP, array(
'vars' => $this->vars,
'user' => $this->user,
'form' => $this->form,
'invoice' => $invoice,
'savedForm' => $this->record
));
$invoice->setUser($this->user);
foreach ($this->vars as $k => $v) {
if (strpos($k, 'product_id')===0)
foreach ((array)$this->vars[$k] as $product_id)
{
@list($product_id, $plan_id, $qty) = explode('-', $product_id, 3);
$product_id = (int)$product_id;
if (!$product_id) continue;
$p = $this->getDi()->productTable->load($product_id);
if ($plan_id > 0) $p->setBillingPlan(intval($plan_id));
$qty = (int)$qty;
if (!$p->getBillingPlan()->variable_qty || ($qty <= 0))
$qty = 1;
$options = array();
if (!empty($this->vars['productOption']["$product_id-$plan_id"]))
{
$options = $this->vars['productOption']["$product_id-$plan_id"][0];
}
$prOpt = $p->getOptions(true);
foreach ($options as $k => $v)
{
$options[$k] = array('value' => $v, 'optionLabel' => $prOpt[$k]->title,
'valueLabel' => $prOpt[$k]->getOptionLabel($v));
}
$invoice->add($p, $qty, $options);
}
}
$event = new Am_Event(Am_Event::SIGNUP_INVOICE_ITEMS, array(
'vars' => $this->vars,
'form' => $this->form,
'invoice' => $invoice,
'savedForm' => $this->record
));
$this->getDi()->hook->call($event);
$invoice = $event->getReturn() ?: $invoice;
if (!$invoice->getItems()) {
$this->form->getSessionContainer()->destroy();
$this->_redirect('login');
return true;
}
if (!empty($this->vars['coupon']))
{
$invoice->setCouponCode($this->vars['coupon']);
$invoice->validateCoupon();
}
$invoice->calculate();
$invoice->setPaysystem(isset($this->vars['paysys_id']) ? $this->vars['paysys_id'] : 'free');
$err = $invoice->validate();
if ($err)
throw new Am_Exception_InputError($err[0]);
if (!empty($this->vars['coupon']) &&
!(float)$invoice->first_discount &&
!(float)$invoice->second_discount) {
$coupon = $this->getDi()->couponTable->findFirstByCode($this->vars['coupon']);
$batch = $coupon->getBatch();
if ($batch->discount > 0) {
$page = $this->form->findPageByElementName('coupon');
if (!$page) throw new Am_Exception_InternalError('Coupon brick is not found but coupon code presents in request');
list($el) = $page->getForm()->getElementsByName('coupon');
$el->setError(___('The coupon entered is not valid with any product(s) being purchased. No discount will be applied'));
//now active datasource is datasource of current page
//retrieve datasource for page with coupon element from
//session and set it to form to populate it correctly
$values = $page->getController()->getSessionContainer()->getValues($page->getForm()->getId());
$page->getForm()->setDataSources(array(
new HTML_QuickForm2_DataSource_Array($values)
));
$page->handle('display');
return false;
}
}
$invoice->insert();
$this->getDi()->hook->call(Am_Event::INVOICE_BEFORE_PAYMENT_SIGNUP, array(
'vars' => $this->vars,
'form' => $this->form,
'invoice' => $invoice,
'savedForm' => $this->record
));
try {
$payProcess = new Am_Paysystem_PayProcessMediator($this, $invoice);
$result = $payProcess->process();
} catch (Am_Exception_Redirect $e) {
$this->form->getSessionContainer()->destroy();
$invoice->refresh();
if ($invoice->isCompleted())
{ // relogin customer if free subscription was ok
$this->autoLoginIfNecessary();
}
throw $e;
}
// if we got back here, there was an error in payment!
/** @todo offer payment method if previous failed */
$page = $this->form->findPageByElementName('paysys_id');
if (!$page) $page = $this->form->getFirstPage(); // just display first page
foreach ($page->getForm()->getElementsByName('paysys_id') as $el)
$el->setValue(null)->setError(current($result->getErrorMessages()));
$page->handle('display');
return false;
}
function getCurrentUrl()
{
$c = $this->getFiltered('c');
return $this->_request->getScheme() . '://' .
$this->_request->getHttpHost() .
$this->_request->getBaseUrl() . '/' .
$this->_request->getControllerName() .
($c ? "/$c" : '');
}
public function getForm()
{
return $this->form;
}
}PK \Ҫ5,[ ,[ A default/controllers/AdminImportWordpressMemberMouseController.phpnu [ db_wordpress = $db;
$this->paysys_id = $paysys_id;
}
function process(User $user, array $order)
{
$this->user = $user;
$this->order = $order;
return $this->doWork();
}
abstract function doWork();
static function factory($paysys_id, DbSimple_Interface $db)
{
$class = 'InvoiceCreator_' . ucfirst(toCamelCase($paysys_id));
if (class_exists($class, false))
return new $class($paysys_id, $db);
else
throw new Exception(sprintf('Unknown Payment System [%s]', $paysys_id));
}
protected function _translateProduct($pid)
{
static $cache = array();
if (empty($cache))
{
$cache = Am_Di::getInstance()->db->selectCol("
SELECT `value` as ARRAY_KEY, `id`
FROM ?_data
WHERE `table`='product' AND `key`='wmm:id'");
}
return @$cache[$pid];
}
protected function insertAccess($access, $invoice_id=null, $payment_id=null)
{
$a = $this->getDi()->accessRecord;
$a->setDisableHooks();
$a->user_id = $this->user->user_id;
$a->begin_date = $access['access_start_date'];
$a->expire_date = $access['access_end_date'];
if (!is_null($invoice_id))
{
$a->invoice_id = $invoice_id;
}
if (!is_null($payment_id))
{
$a->invoice_payment_id = $payment_id;
}
$a->product_id = $access['product_id'];
$a->insert();
}
}
class InvoiceCreator_Paypal extends InvoiceCreator_Abstract
{
function doWork()
{
/*@var $product Product*/
if(!($product = Am_Di::getInstance()->productTable->load($this->_translateProduct($this->order['item_id']), false)))
return;
/*@var $invoice Invoice*/
$invoice = $this->getDi()->invoiceRecord;
$invoice->user_id = $this->user->pk();
$invoice->public_id = $this->order['iid'];
/*@var $item InvoiceItem*/
$item = $invoice->createItem($product);
$item->qty = $this->order['quantity'];
$item->first_discount = 0;
$item->first_shipping = 0;
$item->first_tax = 0;
$item->second_discount = 0;
$item->second_shipping = 0;
$item->second_tax = 0;
$item->_calculateTotal();
$invoice->addItem($item);
$invoice->paysys_id = 'paypal';
$invoice->tm_added = $this->order['date_added'];
$invoice->tm_started = $this->order['date_added'];
$invoice->calculate();
$invoice->insert();
$payments = $this->db_wordpress->select("
SELECT
txn_id, subscr_id, received, txn_type, ipn_content
FROM mm_paypal_ipn_log
WHERE
order_id = ?d
AND (payment_status = ? OR txn_type = ?)
", $this->order['order_id'], 'Completed', 'subscr_cancel');
$cnt = 0;
foreach ($payments as $p)
{
$invoice->data()->set('external_id', $p['subscr_id']);
if($p['txn_type'] == 'subscr_cancel')
{
$invoice->tm_cancelled = $p['received'];
$invoice->status = Invoice::RECURRING_CANCELLED;
continue;
}
$data = unserialize($p['ipn_content']);
$amount = ($a = $data['mc_gross']) ? $a : $data['payment_gross'];
/*@var $payment InvoicePayment*/
$payment = $this->getDi()->invoicePaymentRecord;
$payment->user_id = $this->user->user_id;
$payment->invoice_id = $invoice->pk();
$payment->currency = $data['mc_currency'];
$payment->amount = moneyRound($amount);
$payment->paysys_id = 'paypal';
$payment->dattm = $p['received'];
$payment->receipt_id = $p['subscr_id'];
$payment->transaction_id = 'import-paypal-' . $p['txn_id'];
$payment->insert();
// access
$start = sqlDate($p['received']);
$period = new Am_Period($cnt ? $invoice->second_period : $invoice->first_period);
$expire = $period->addTo($start);
$access = array(
'product_id' => $product->pk(),
'access_start_date' => $start,
'access_end_date' => $expire,
);
$this->insertAccess($access, $invoice->pk(), $payment->pk());
$cnt++;
}
$invoice->update();
$this->user->checkSubscriptions();
}
}
class InvoiceCreator_AuthorizeCim extends InvoiceCreator_Abstract
{
function doWork()
{
/*@var $product Product*/
if(!($product = Am_Di::getInstance()->productTable->load($this->_translateProduct($this->order['item_id']), false)))
return;
/*@var $invoice Invoice*/
$invoice = $this->getDi()->invoiceRecord;
$invoice->user_id = $this->user->pk();
$invoice->public_id = $this->order['iid'];
/*@var $item InvoiceItem*/
$item = $invoice->createItem($product);
$item->qty = $this->order['quantity'];
$item->first_discount = 0;
$item->first_shipping = 0;
$item->first_tax = 0;
$item->second_discount = 0;
$item->second_shipping = 0;
$item->second_tax = 0;
$item->_calculateTotal();
$invoice->addItem($item);
$invoice->paysys_id = 'authorize-cim';
$invoice->tm_added = $this->order['date_added'];
$invoice->tm_started = $this->order['date_added'];
$invoice->calculate();
$invoice->insert();
$payments = $this->db_wordpress->select("
SELECT
id, charge_id, amount, transaction_date
FROM mm_authorizenet_cim_charges
WHERE order_id = ?d
", $this->order['order_id']);
$cnt = 0;
foreach ($payments as $p)
{
/*@var $payment InvoicePayment*/
$payment = $this->getDi()->invoicePaymentRecord;
$payment->user_id = $this->user->user_id;
$payment->invoice_id = $invoice->pk();
$payment->currency = $invoice->currency;
$payment->amount = moneyRound($p['amount']);
$payment->paysys_id = 'authorize-cim';
$payment->dattm = $p['transaction_date'];
$payment->receipt_id = $p['charge_id'];
$payment->transaction_id = 'import-authorizecim-' . $p['charge_id'];
$payment->insert();
$r = $this->db_wordpress->selectRow("
SELECT tl2.transaction_date, tl2.amount
FROM mm_transaction_log tl1
LEFT JOIN mm_transaction_log tl2 ON tl1.refund_id = tl2.id
WHERE
tl1.payment_service_id = ?d
AND tl1.payment_service_detail_id = ?d
", 3, $p['id']); // 3 - auth-cim
if(!empty($r['transaction_date']))
{
/*@var $refund InvoiceRefund*/
$refund = $this->getDi()->invoiceRefundRecord;
$refund->invoice_id = $invoice->pk();
$refund->user_id = $this->user->pk();
$refund->paysys_id = $invoice->paysys_id;
$refund->receipt_id = $refund->transaction_id = "refunded-" . $p['charge_id'];
$refund->dattm = $r['transaction_date'];
$refund->currency = $invoice->currency;
$refund->amount = moneyRound($r['amount']);
$refund->insert();
$invoice->updateQuick(array('tm_cancelled' => $r['transaction_date'], 'status' => Invoice::RECURRING_CANCELLED));
} else
{
$start = sqlDate($p['transaction_date']);
$period = new Am_Period($cnt ? $invoice->second_period : $invoice->first_period);
$expire = $period->addTo($start);
$access = array(
'product_id' => $product->pk(),
'access_start_date' => $start,
'access_end_date' => $expire,
);
$this->insertAccess($access, $invoice->pk(), $payment->pk());
}
$cnt++;
}
$invoice->update();
$this->user->checkSubscriptions();
}
}
abstract class Am_Import_Abstract extends Am_BatchProcessor
{
/** @var DbSimple_Mypdo */
protected $db_wordpress;
protected $options = array();
/** @var Zend_Session_Namespace */
protected $session;
public function __construct(DbSimple_Interface $db_wordpress, array $options = array())
{
$this->db_wordpress = $db_wordpress;
$this->options = $options;
$this->session = new Zend_Session_Namespace(get_class($this));
parent::__construct(array($this, 'doWork'));
$this->init();
}
public function init()
{
}
public function run(&$context)
{
$ret = parent::run($context);
if ($ret)
$this->session->unsetAll();
return $ret;
}
/** @return Am_Di */
public function getDi()
{
return Am_Di::getInstance();
}
abstract public function doWork(& $context);
}
class Am_Import_Product3 extends Am_Import_Abstract
{
public function doWork(&$context)
{
$importedProducts = $this->getDi()->db->selectCol("SELECT `value` FROM ?_data WHERE `table`='product' AND `key`='wmm:id'");
$q = $this->db_wordpress->queryResultOnly("SELECT * FROM mm_products");
while ($r = $this->db_wordpress->fetchRow($q))
{
if (in_array($r['id'], $importedProducts))
continue;
$context++;
$p = $this->getDi()->productRecord;
$p->title = $r['name'];
$p->description = $r['description'];
$p->currency = $r['currency'];
$p->is_disabled = $r['status'] ? 1 : 0;
$p->data()->set('wmm:id', $r['id']);
$p->insert();
/*@var $bp BillingPlan*/
$bp = $p->createBillingPlan();
$bp->title = 'default';
if($r['has_trial'])
{
$bp->first_price = moneyRound($r['trial_amount']);
$bp->first_period = $this->parsePeriod($r['trial_duration'], $r['trial_frequency']);
} else
{
$bp->first_price = moneyRound($r['price']);
$bp->first_period = ($r['rebill_period'] && $r['rebill_frequency'])
? $this->parsePeriod($r['rebill_period'], $r['rebill_frequency'])
: Am_Period::MAX_SQL_DATE;
}
if($r['rebill_period'] && $r['rebill_frequency'])
{
$bp->rebill_times = ($r['do_limit_payments']) ? $r['number_of_payments'] : IProduct::RECURRING_REBILLS;
$bp->second_price = moneyRound($r['price']);
$bp->second_period = $this->parsePeriod($r['rebill_period'], $r['rebill_frequency']);
}
$bp->insert();
}
return true;
}
protected function parsePeriod($count, $unit)
{
$c = $count;
switch ($unit)
{
case 'days':
$u = 'd';
break;
case 'weeks':
$c *= 7;
$u = 'd';
break;
case 'months':
$u = 'm';
break;
case 'years':
$u = 'y';
break;
default :
throw new Am_Exception_InputError("Unknown period unit [{$unit}]");
}
return $c . $u;
}
}
class Am_Import_User3 extends Am_Import_Abstract
{
function doWork(& $context)
{
$maxImported = (int) $this->getDi()->db->selectCell("
SELECT `value` FROM ?_data WHERE `table`='user' AND `key`='wmm:id' ORDER BY `id` DESC LIMIT 1
");
$count = @$this->options['count'];
if ($count)
$count -= $context;
if ($count < 0)
return true;
$q = $this->db_wordpress->queryResultOnly("
SELECT
u.*,
um1.meta_value as first_name,
um2.meta_value as last_name,
accl.authnet_customer_id,
accl.authnet_payment_id
FROM ?_users u
LEFT JOIN ?_usermeta um1 on u.ID = um1.user_id and um1.meta_key = 'first_name'
LEFT JOIN ?_usermeta um2 on u.ID = um2.user_id and um2.meta_key = 'last_name'
LEFT JOIN mm_authorizenet_cim_customer_links accl on u.ID = accl.membermouse_customer_id
WHERE u.ID > ?d
ORDER BY u.ID
{LIMIT ?d}
", $maxImported, $count ? $count : DBSIMPLE_SKIP);
while ($r = $this->db_wordpress->fetchRow($q))
{
if (!$this->checkLimits())
return;
$u = $this->getDi()->userRecord;
$u->email = $r['user_email'];
$u->added = $r['user_registered'];
$u->login = $r['user_login'];
$u->name_f = (string)$r['first_name'];
$u->name_l = (string)$r['last_name'];
$u->is_approved = 1;
$u->data()->set('wmm:id', $r['ID']);
$u->data()->set('signup_email_sent', 1); // do not send signup email second time
if($cid = $r['authnet_customer_id'])
$u->data()->set('authorize_cim_user_profile_id', $cid);
if($pid = $r['authnet_payment_id'])
$u->data()->set('authorize_cim_payment_profile_id', $pid);
$u->pass = $r['user_pass'];
try
{
$u->insert();
if($cid || $pid)
{
$storedCc = $this->getDi()->CcRecordRecord;
$storedCc->user_id = $u->pk();
$storedCc->cc_expire = '1237';
$storedCc->cc_number = '0000000000000000';
$storedCc->cc = $storedCc->maskCc($storedCc->cc_number);
$storedCc->insert();
}
$this->insertPayments($r['ID'], $u);
$context++;
}
catch (Am_Exception_Db_NotUnique $e)
{
echo "Could not import user: " . $e->getMessage() . "
\n";
}
}
return true;
}
function insertPayments($id, User $u)
{
$orders = $this->db_wordpress->select("
SELECT
o.id as order_id, o.order_number as iid, o.payment_id, o.date_added, oi.item_id, oi.quantity
FROM mm_orders o
LEFT JOIN mm_order_items oi ON oi.order_id=o.id
WHERE
oi.item_id > 0
AND o.payment_id IN (?a)
AND o.user_id = ?d
", array(1,3), $id);
foreach ($orders as $order)
{
switch ($order['payment_id'])
{
case 1:
InvoiceCreator_Abstract::factory('paypal', $this->db_wordpress)->process($u, $order);
break;
case 3:
InvoiceCreator_Abstract::factory('authorize-cim', $this->db_wordpress)->process($u, $order);
break;
default:
break;
}
}
}
}
class AdminImportWordpressMemberMouseController extends Am_Mvc_Controller
{
/** @var Am_Form_Admin */
protected $dbForm;
/** @var DbSimple_Mypdo */
protected $db_wordpress;
public function checkAdminPermissions(Admin $admin)
{
return $admin->hasPermission(Am_Auth_Admin::PERM_SUPER_USER);
}
function indexAction()
{
Am_Mail::setDefaultTransport(new Am_Mail_Transport_Null());
if ($this->_request->get('start'))
{
$this->getSession()->wordpress_db = null;
$this->getSession()->wordpress_import = null;
}
elseif ($this->_request->get('import_settings'))
{
$this->getSession()->wordpress_import = null;
}
if (!$this->getSession()->wordpress_db)
return $this->askDbSettings();
$this->db_wordpress = Am_Db::connect($this->getSession()->wordpress_db);
if (!$this->getSession()->wordpress_import)
return $this->askImportSettings();
// disable ALL hooks
$this->getDi()->hook = new Am_Hook($this->getDi());
$done = $this->_request->getInt('done', 0);
$importSettings = $this->getSession()->wordpress_import;
$import = $this->_request->getFiltered('i', $importSettings['import']);
$class = "Am_Import_" . ucfirst($import) . "3";
$importer = new $class($this->db_wordpress, (array) @$importSettings[$import]);
if ($importer->run($done) === true)
{
$this->view->title = ucfirst($import) . " Import Finished";
$this->view->content = "$done records imported from Wordpress Member Mouse Plugin";
$this->view->content .= "
Continue to import other information";
$this->view->content .= "
Do not forget to >Rebuild Db after all import operations are done.";
$this->view->display('admin/layout.phtml');
$this->getSession()->wordpress_import = null;
}
else
{
$this->redirectHtml($this->getDi()->url("admin-import-wordpress-member-mouse", array('done'=>$done,'i'=>$import),false), "$done records imported");
}
}
function askImportSettings()
{
$this->form = $this->createImportForm($defaults);
$this->form->addDataSource($this->_request);
if (!$this->form->isSubmitted())
$this->form->addDataSource(new HTML_QuickForm2_DataSource_Array($defaults));
if ($this->form->isSubmitted() && $this->form->validate())
{
$val = $this->form->getValue();
if (@$val['import'])
{
$this->getSession()->wordpress_import = array(
'import' => $val['import'],
'user' => @$val['user'],
'pr_link' => @$val['pr_link'],
);
$this->_redirect('admin-import-wordpress-member-mouse');
return;
}
}
$this->view->title = "Import Wordpress Member Mouse Plugin Information";
$this->view->content = (string) $this->form;
$this->view->display('admin/layout.phtml');
}
function createImportForm(& $defaults)
{
$form = new Am_Form_Admin;
/** count imported */
$imported_products =
$this->getDi()->db->selectCell("SELECT COUNT(id) FROM ?_data WHERE `table`='product' AND `key`='wmm:id'");
$total = $this->db_wordpress->selectCell("SELECT COUNT(*) FROM mm_products");
if ($imported_products >= $total)
{
$cb = $form->addStatic()->setContent("Imported ($imported_products of $total)");
}
else
{
$cb = $form->addRadio('import', array('value' => 'product'));
}
$cb->setLabel('Import Products');
if ($imported_products)
{
$imported_users =
$this->getDi()->db->selectCell("SELECT COUNT(id) FROM ?_data WHERE `table`='user' AND `key`='wmm:id'");
$total = $this->db_wordpress->selectCell("SELECT COUNT(*) FROM ?_users");
if ($imported_users >= $total)
{
$cb = $form->addStatic()->setContent("Imported ($imported_users)");
}
else
{
$cb = $form->addGroup();
if ($imported_users)
$cb->addStatic()->setContent("partially imported ($imported_users of $total total)
");
$cb->addRadio('import', array('value' => 'user'));
$cb->addStatic()->setContent('
# of users (keep empty to import all) ');
$cb->addInteger('user[count]');
}
$cb->setLabel('Import User and Payment Records');
}
$form->addSaveButton('Run');
$defaults = array(
//'user' => array('start' => 5),
);
return $form;
}
function askDbSettings()
{
$this->form = $this->createMysqlForm();
if ($this->form->isSubmitted() && $this->form->validate())
{
$this->getSession()->wordpress_db = $this->form->getValue();
$this->_redirect('admin-import-wordpress-member-mouse');
}
else
{
$this->view->title = "Import Wordpress Membership Information";
$this->view->content = (string) $this->form;
$this->view->display('admin/layout.phtml');
}
}
/** @return Am_Form_Admin */
function createMysqlForm()
{
$form = new Am_Form_Admin;
$el = $form->addText('host')->setLabel('Wordpress MySQL Hostname');
$el->addRule('required', 'This field is required');
$form->addText('user')->setLabel('Wordpress MySQL Username')
->addRule('required', 'This field is required');
$form->addPassword('pass')->setLabel('Wordpress MySQL Password');
$form->addText('db')->setLabel('Wordpress MySQL Database Name')
->addRule('required', 'This field is required');
$form->addText('prefix')->setLabel('Wordpress Tables Prefix');
$dbConfig = $this->getDi()->getParameter('db');
$form->addDataSource(new HTML_QuickForm2_DataSource_Array(array(
'host' => $dbConfig['mysql']['host'],
'user' => $dbConfig['mysql']['user'],
'prefix' => 'wp_',
)));
$el->addRule('callback2', '-', array($this, 'validateDbConnect'));
$form->addSubmit(null, array('value' => 'Continue...'));
return $form;
}
function validateDbConnect()
{
$config = $this->form->getValue();
try
{
$db = Am_Db::connect($config);
if (!$db)
return "Check database settings - could not connect to database";
$db->query("SELECT * FROM ?_users LIMIT 1");
}
catch (Exception $e)
{
return "Check database settings - " . $e->getMessage();
}
}
}
PK \* * default/controllers/SendpassController.phpnu [ getFiltered(self::SECURITY_VAR)) {
if ($this->checkCode($code, $user)) {
$this->doChangePass($user, $code);
} else {
throw new Am_Exception_InputError(___('Security code is either invalid or expired'));
}
} else {
$this->doSend();
}
}
public function doSend()
{
$res = array();
if (Am_Recaptcha::isConfigured() && $this->getDi()->config->get('recaptcha')) {
$res['recaptcha_key'] = $this->getDi()->recaptcha->getPublicKey();
}
do {
if (Am_Recaptcha::isConfigured() &&
$this->getDi()->config->get('recaptcha') &&
!$this->getDi()->recaptcha->validate($this->getParam('g-recaptcha-response'))) {
$ok = false;
$text = ___('Anti Spam check failed');
break;
}
$login = trim($this->getParam('login'));
$user = $this->getDi()->userTable->findFirstByLogin($login);
if (!$user)
$user = $this->getDi()->userTable->findFirstByEmail($login);
if (!$user) {
$title = ___('Lost Password Sending Error');
$text = ___('The information you have entered is incorrect. ' .
'Username [%s] does not exist in database', $this->getEscaped('login'));
$ok = false;
break;
}
if ($error = $this->checkLimits($user)) {
$title = ___('Lost Password Sending Error');
$text = $error;
$ok = false;
break;
}
$this->sendSecurityCode($user);
$title = ___('Lost Password Sent');
$text = ___('Your password has been e-mailed to you. ' .
'Please check your mailbox');
$ok = true;
} while (false);
if ($this->_request->isXmlHttpRequest())
{
$res['ok'] = $ok;
$res['error'] = array($text);
return $this->_response->ajaxResponse($res);
}
$this->view->title = $title;
$this->view->content = $text;
$this->view->display('layout.phtml');
}
public function doChangePass(User $user, $code)
{
$form = $this->createForm();
$form->addDataSource(new HTML_QuickForm2_DataSource_Array(array(
self::SECURITY_VAR => $code,
'login' => $user->login
)));
if ($form->isSubmitted() && $form->validate())
{
$user->setPass($this->getParam('pass0'));
$user->save();
$this->getDi()->store->delete(self::STORE_PREFIX . $code);
$msg = ___('Your password has been changed successfully. ' .
'You can %slogin to your account%s with new password.',
sprintf('', $this->getDi()->url('login')), '');
$this->view->title = ___('Change Password');
$this->view->content = <<$msg\n";
$cnt .= highlight_string($view->render('admin/plugin-template.phtml'), true);
$cnt .= "
";
$el = $this->form->addStatic(null, array('class'=>'no-label'))->setContent($cnt);
$gr = $this->form->addGroup(null, array('class' => 'no-label', 'style' => 'text-align:center'));
$gr->addSubmit($this->getButtonName('back'), array('value'=>'Back'));
$page = $this;
while ($p = $page->getController()->previousPage($page))
$page = $p;
$gr->addSubmit($page->getButtonName('jump'), array('value'=>'Start Over'));
}
}
class Am_Form_Controller_Page_PluginMaker_Mysql extends HTML_QuickForm2_Controller_Page
{
protected function populateForm()
{
$this->getController()->destroySessionContainer();
$this->form->addStatic('Enter third-party plugin database connection details');
$this->form->addText('host')->setLabel('MySQL Hostname')->addRule('required');
$this->form->addText('port')->setLabel('MySQL Port');
$this->form->addText('user')->setLabel('MySQL Username')->addRule('required');
$this->form->addPassword('pass')->setLabel('MySQL Password');
$this->form->addText('db')->setLabel('MySQL Database')->addRule('required');
$this->form->addSubmit($this->getButtonName('next'), array('value'=>'Next'));
$this->form->addRule('callback2', '-', array($this, 'validateMysql'));
$this->form->addDataSource(new HTML_QuickForm2_DataSource_Array(array('port' => 3606)));
}
function validateMysql(array $info)
{
try {
Am_Db::connect($info);
} catch (Am_Exception_Db $e) {
return "Wrong info: " . $e->getMessage();
}
}
}
class Am_Form_Controller_Page_PluginMaker_Plugin extends HTML_QuickForm2_Controller_Page
{
protected function populateForm()
{
$this->form->addText('plugin')->setLabel('Plugin Id')
->addRule('required')
->addRule('regex', 'Must match regex /[a-z][a-z0-9-]+/', '/^[a-z][a-z0-9-]+$/');
$sel = $this->form->addSelect('password_type')->setLabel('Password Type');
$sel->addOption('-- Select --', '');
$sel->addRule('required');
$class = new ReflectionClass('SavedPassTable');
foreach ($class->getConstants() as $k => $v)
if (strpos($k, 'PASSWORD')===0)
$sel->addOption('SavedPassTable::'.$k . ' ('.$v.')', 'SavedPassTable::'.$k);
$sel->addOption('Custom (define method)', 'custom');
$sel = $this->form->addSelect('group_mode')->setLabel('Group Mode');
$sel->addOption('-- Select --', '');
$sel->addRule('required');
$class = new ReflectionClass('Am_Protect_Databased');
foreach ($class->getConstants() as $k => $v)
if (strpos($k, 'GROUP_')===0)
$sel->addOption($class->getName().'::'.$k, $class->getName().'::'.$k);
$gr = $this->form->addGroup(null, array('class' => 'no-label', 'style' => 'text-align:center'));
$gr->addSubmit($this->getButtonName('back'), array('value'=>'Start Over'));
$gr->addSubmit($this->getButtonName('next'), array('value'=>'Next'));
}
}
class Am_Form_Controller_Page_PluginMaker_Tables extends HTML_QuickForm2_Controller_Page
{
protected function populateForm()
{
$info = $this->getController()->getValue();
$db = Am_Db::connect($info);
$tables = $db->selectCol("SHOW TABLES");
$tables = array_merge(array('' => '-- Select --'), array_combine($tables, $tables));
$this->form->addSelect('table[user]')->setLabel('User Table')
->loadOptions($tables)->addRule('required');
if ($info['group_mode'] != 'Am_Protect_Databased::GROUP_NONE')
{
$this->form->addSelect('table[group]')->setLabel('Groups Table')
->loadOptions($tables)->addRule('required');
if ($info['group_mode'] != 'Am_Protect_Databased::GROUP_SINGLE')
$this->form->addSelect('table[usergroup]')->setLabel('User<->Group Relation Table (optional)')
->loadOptions($tables);
}
$this->form->addSelect('table[session]')->setLabel('Session Storage Table (optional)')
->loadOptions($tables);
$prefixes = $this->findPrefixes($tables);
$options = @array_merge(array('' => 'No Prefix'), @array_combine($prefixes, $prefixes));
$this->form->addSelect('table_prefix')->setLabel('Tables Prefix')->loadOptions((array)$options);
$gr = $this->form->addGroup(null, array('class' => 'no-label', 'style' => 'text-align:center'));
$gr->addSubmit($this->getButtonName('back'), array('value'=>'Back'));
$gr->addSubmit($this->getButtonName('next'), array('value'=>'Next'));
}
/**
* find most possible prefixes
*/
function findPrefixes(array $tables)
{
$found = array();
foreach ($tables as $t)
{
$a = explode('_', $t);
if (count($a)>1)
{
@$found[$a[0] . '_']++;
}
}
return array_keys($found);
}
}
class Am_Form_Controller_Page_PluginMaker_Columns extends HTML_QuickForm2_Controller_Page
{
public function addTable($name, Am_Table $table, $title, array $options)
{
$fs = $this->form->addFieldset()->setLabel($title . ' Columns: ' . $table->getName(true));
$sampleRows = $table->getAdapter()->select("SELECT * FROM ?#
LIMIT ?d,3", $table->getName(true), max($table->countBy() - 3, 0));
$key = null;
foreach ($table->getFields() as $fieldName => $f)
{
if ($f->key == 'PRI')
$key = $fieldName;
unset($f->field);
unset($f->null);
$gr = $fs->addGroup('field['.$name . ']['.$fieldName.']')
->setLabel($fieldName . "\n". implode(' ', get_object_vars($f)));
if ($fieldName != $key)
{
$options = array_merge(array('' => '-- Select --'), $options);
$gr->addSelect('field', array('class' => 'field'))->loadOptions($options);
$gr->addText('text', array('size'=>'40', 'style' => 'display:none'));
}
$sample = "";
foreach ($sampleRows as $r)
{
$v = Am_Html::escape($r[$fieldName]);
if (strlen($v) > 60) $v = substr($v, 0, 60) . '...cut';
$sample .= $v . "
";
}
$sample .= "
";
$gr->addStatic()->setContent($sample);
}
if (!$key) $key = current($table->getFields(true));
$this->form->addHidden('key['.$name.']')->setValue($key);
}
public function addFieldSelect($name, Am_Table $table, $title, array $options)
{
$fs = $this->form->addFieldset()->setLabel($title . ' Columns: ' . $table->getName(true));
$sampleRows = $table->getAdapter()->select("SELECT * FROM ?#
LIMIT ?d,3", $table->getName(true), max($table->countBy() - 3, 0));
$sample = "";
foreach ($sampleRows as $r)
{
$sample .= nl2br(Am_Html::escape(substr(print_r($r, true), 0, 1024))) . "\n";
}
$sample .= "
";
$fs->addStatic()->setLabel('Sample Rows')->setContent($sample);
$fields = $table->getFields(true);
$fields = array_merge(array(''), $fields);
foreach ($options as $k => $v)
{
$el = $fs->addSelect('field['.$name . ']['.$k.']')->setLabel($v)
->loadOptions(array_combine($fields, $fields));
if (!in_array($k,array('Am_Protect_SessionTable::FIELD_UID',
'Am_Protect_SessionTable::FIELD_IP',
'Am_Protect_SessionTable::FIELD_UA',
'Am_Protect_SessionTable::FIELD_CREATED',
'Am_Protect_SessionTable::FIELD_CHANGED')))
$el->addRule('required');
}
}
protected function populateForm()
{
$info = $this->getController()->getValue();
$db = Am_Db::connect($info);
$tables = array();
foreach ($info['table'] as $k => $v)
{
if (!empty($v))
$tables[$k] = new Am_Table($db, $v);
}
/// user table
$userOptions = array('expr' => 'PHP Expression', 'string' => 'PHP String');
$class = new ReflectionClass('Am_Protect_Table');
foreach ($class->getConstants() as $k => $v)
{
if (strpos($k, 'FIELD_')!==0) continue;
$userOptions[$class->getName() . '::' . $k] = $class->getName() . ':' . $k;
}
$this->addTable('user', $tables['user'], 'User Table', $userOptions);
/// group table
if (!empty($tables['group']))
{
$groupOptions = array(
'id' => 'Group ID',
'title' => 'Group Title',
);
$this->addFieldSelect('group', $tables['group'], 'Group Table', $groupOptions);
}
/// user <-> group table
if (!empty($tables['usergroup']))
{
$usergroupOptions = array(
'Am_Protect_Table::GROUP_UID' => 'User ID',
'Am_Protect_Table::GROUP_GID' => 'Group ID',
);
$this->addFieldSelect('usergroup', $tables['usergroup'], 'User<->Group Table', $usergroupOptions);
}
/// session table
if (!empty($tables['session']))
{
$sessionOptions = array(
'Am_Protect_SessionTable::FIELD_SID' => 'Session ID',
'Am_Protect_SessionTable::FIELD_UID' => 'User ID',
'Am_Protect_SessionTable::FIELD_IP' => 'IP Address',
'Am_Protect_SessionTable::FIELD_UA' => 'User Agent',
'Am_Protect_SessionTable::FIELD_CREATED' => 'Created',
'Am_Protect_SessionTable::FIELD_CHANGED' => 'Changed',
);
$this->addTable('session', $tables['session'], 'Session Table', $sessionOptions);
}
$this->form->addScript()->setScript(<<