plugins/shop/admin_modules/yf_manage_shop_revisions.class.php
<?php
class yf_manage_shop_revisions
{
public function show()
{
return table('SELECT * FROM ' . db('shop_revisions'), [
'filter' => true,
'filter_params' => [
'user_id' => ['eq', 'user_id'],
'add_date' => ['dt_between', 'add_date'],
'action' => ['eq', 'action'],
'item_id' => ['eq', 'item_id'],
'ip' => ['like', 'ip'],
],
'hide_empty' => 1,
])
->date('add_date', ['format' => '%d-%m-%Y', 'nowrap' => 1])
->admin('user_id', ['desc' => 'admin'])
->text('ip')
->text('action')
->text('item_id')
->btn_view('', './?object=manage_shop_revisions&action=details&id=%d');
}
/**
* @param mixed $function
* @param mixed $ids
* @param mixed $db_table
*/
public function new_revision($function, $ids, $db_table)
{
if (empty($function) || empty($ids) || empty($db_table)) {
return false;
}
if ( ! is_array($ids) && (int) $ids) {
$ids = [(int) $ids];
}
$user_id = (int) (main()->ADMIN_ID) ?: (int) ($_GET['admin_id']);
$add_rev_date = time();
foreach ((array) $ids as $id) {
$data_stump = db()->query_fetch('SELECT * FROM ' . db($db_table) . ' WHERE id=' . $id);
$data_stump_json = json_encode($data_stump);
$check_equal_data = db()->get_one('SELECT data FROM ' . db('shop_revisions') . ' WHERE item_id=' . $id . ' ORDER BY id DESC');
if ($data_stump_json == $check_equal_data) {
continue;
}
$insert = [
'user_id' => $user_id,
'add_date' => $add_rev_date,
'action' => $function,
'item_id' => $id,
'ip' => common()->get_ip(),
'table' => $db_table,
'data' => $data_stump_json ?: '',
];
db()->insert_safe('shop_revisions', $insert);
$revisions_ids[] = db()->insert_id();
}
return $revision_ids;
}
/**
* @param mixed $function
* @param mixed $id
* @param mixed $db_table
*/
public function check_revision($function, $id, $db_table)
{
if (empty($function) || empty($id) || empty($db_table)) {
return false;
}
if ( ! is_array($id) && (int) $id) {
$ids = [(int) $id];
}
$check_ids = db()->get_2d('SELECT id, item_id FROM ' . db('shop_revisions') . ' WHERE item_id IN (' . implode(',', $ids) . ') AND action=\'' . $function . '\'');
$ids = array_diff($ids, (array) $check_ids);
return $this->new_revision($function, $ids, $db_table);
}
public function details()
{
$sql = 'SELECT * FROM ' . db('shop_revisions') . ' WHERE id=' . (int) ($_GET['id']);
$a = db()->get($sql);
if (empty($a)) {
return _e('Revision not found');
}
return form($a, [
'dd_mode' => 1,
])
->link('Revisions list', './?object=manage_shop_revisions')
->admin_info('user_id')
->info_date('add_date', ['format' => 'full'])
->info('action')
->link('Activate new version', './?object=manage_shop_revisions&action=rollback_revision&id=' . $a['id'])
->tab_start('View_difference')
->func('data', function ($extra, $r, $_this) {
$origin = json_decode($r[$extra['name']], true);
$before = db()->get('SELECT * FROM ' . db('shop_revisions') . ' WHERE id<' . $r['id'] . ' AND item_id=' . $r['item_id'] . ' ORDER BY id DESC');
$before = json_decode($before[$extra['name']], true);
$origin = var_export($origin, true);
$before = var_export($before, true);
return common()->get_diff($before, $origin);
})
->tab_end()
->tab_start('New_version')
->func('data', function ($extra, $r, $_this) {
return '<pre>' . var_export(json_decode($r[$extra['name']], true), 1) . '</pre>';
})
->tab_end();
}
public function filter_save()
{
$_GET['id'] = preg_replace('~[^0-9a-z_]+~ims', '', $_GET['id']);
if ($_GET['id'] && false !== strpos($_GET['id'], $_GET['object'] . '__')) {
$filter_name = $_GET['id'];
list(, $action) = explode('__', $filter_name);
}
if ($_GET['page'] == 'clear') {
$_SESSION[$filter_name] = [];
} else {
$_SESSION[$filter_name] = $_POST;
foreach (explode('|', 'clear_url|form_id|submit') as $f) {
if (isset($_SESSION[$filter_name][$f])) {
unset($_SESSION[$filter_name][$f]);
}
}
}
return js_redirect('./?object=' . $_GET['object'] . '&action=' . $action);
}
public function _show_filter()
{
$filters = [
'show' => function ($filter_name, $replace) {
$fields = ['id', 'add_date', 'action', 'item_id', 'ip', 'user_id'];
foreach ((array) $fields as $v) {
$order_fields[$v] = $v;
}
$action = db()->get_2d('SELECT DISTINCT action FROM ' . db('shop_revisions'));
$action = array_combine($action, $action);
return form($replace, [
'filter' => true,
])
->datetime_select('add_date', null, ['with_time' => 1])
->datetime_select('add_date__and', null, ['with_time' => 1])
->text('user_id', 'Админ')
->text('ip')
->select_box('action', $action, ['no_translate' => 1, 'show_text' => 1])
->select_box('order_by', $order_fields, ['no_translate' => 1, 'show_text' => 1]);
},
];
$action = $_GET['action'];
if (isset($filters[$action])) {
return $filters[$action]($filter_name, $replace)
->order_box()
->save_and_clear();
}
return false;
}
public function _hook_side_column()
{
$rev = db()->get('SELECT * FROM ' . db('shop_revisions') . ' WHERE id=' . (int) ($_GET['id']));
if ( ! $rev) {
return false;
}
$sql = 'SELECT * FROM ' . db('shop_revisions') . ' WHERE item_id=' . (int) ($rev['item_id']) . ' AND action !=\'\' ORDER BY id DESC';
return table($sql, [
'caption' => t('Product revisions'),
'no_records_html' => '',
'tr' => [
$rev['id'] => ['class' => 'success'],
],
'pager_records_on_page' => 10,
'btn_no_text' => 1,
'no_header' => 1,
])
->date('add_date', ['format' => '%d/%m/%Y', 'nowrap' => 1])
->admin('user_id', ['desc' => 'admin'])
->text('action')
->btn_view('', './?object=manage_shop_revisions&action=details&id=%d&page=' . $_GET['page']);
}
public function rollback_revision()
{
$_GET['id'] = (int) ($_GET['id']);
$revision_data = db()->get('SELECT * FROM ' . db('shop_revisions') . ' WHERE id=' . $_GET['id']);
if (empty($revision_data)) {
return _e('Revision not found');
}
if (empty($revision_data['table'])) {
return _e('Revision failed');
}
$data_stamp = json_decode($revision_data['data'], true);
$check_db_row = db()->get('SELECT * FROM ' . db($revision_data['table']) . ' WHERE id=' . $revision_data['item_id']);
db()->begin();
if ($data_stamp) {
if ($check_db_row) {
db()->update_safe(db($revision_data['table']), $data_stamp, 'id =' . $revision_data['item_id']);
} else {
db()->insert_safe(db($revision_data['table']), $data_stamp);
}
} else {
db()->query('DELETE FROM ' . db($revision_data['table']) . ' WHERE id =' . $revision_data['item_id']);
}
$this->new_revision($revision_data['action'], $revision_data['item_id'], $revision_data['table']);
db()->commit();
common()->message_success('Revision retrieved');
common()->admin_wall_add(['Rollback common revision: ' . $_GET['id'], $_GET['id']]);
return js_redirect('./?object=manage_shop_revisions&action=details&id=' . $_GET['id']);
}
}