add migrate-content in ugrade

This commit is contained in:
Ronald Q
2016-07-20 11:48:10 -04:00
parent 60f9a8e094
commit 595dd847c3
2 changed files with 80 additions and 53 deletions

View File

@@ -824,59 +824,22 @@ function migrate_counters($command, $args) {
} }
/*----------------------------------********---------------------------------*/ /*----------------------------------********---------------------------------*/
function run_migrate_content($args) { function run_migrate_content($args, $opts) {
G::LoadSystem('inputfilter'); G::LoadSystem('inputfilter');
$filter = new InputFilter(); $filter = new InputFilter();
$args = $filter->xssFilterHard($args); $args = $filter->xssFilterHard($args);
$workspaces = get_workspaces_from_args($args); $workspaces = get_workspaces_from_args($args);
$lang = array_key_exists("lang", $opts) ? $opts['lang'] : SYS_LANG;
$start = microtime(true);
CLI::logging("> Optimizing content data...\n");
foreach ($workspaces as $workspace) { foreach ($workspaces as $workspace) {
if (!defined('SYS_SYS')) { if (!defined('SYS_SYS')) {
define('SYS_SYS', $workspace->name); define('SYS_SYS', $workspace->name);
} }
print_r('Regenerating content in: ' . pakeColor::colorize($workspace->name, 'INFO') . "\n"); print_r('Regenerating content in: ' . pakeColor::colorize($workspace->name, 'INFO') . "\n");
migrate_content($workspace); CLI::logging("-> Regenerating content \n");
$workspace->migrateContentRun($workspace->name, $lang);
} }
$stop = microtime(true);
CLI::logging("<*> Optimizing content data Process took " . ($stop - $start) . " seconds.\n");
} }
function migrate_content($workspace) {
if ((!class_exists('Memcache') || !class_exists('Memcached')) && !defined('MEMCACHED_ENABLED')) {
define('MEMCACHED_ENABLED', false);
}
$content = array(
'Groupwf' => array(
'uid' => 'GRP_UID',
'fields' => array('GRP_TITLE'),
'methods' => array('exists' => 'GroupwfExists')
),
'Process' => array(
'uid' => 'PRO_UID',
'fields' => array('PRO_TITLE', 'PRO_DESCRIPTION'),
'methods' => array('exists' => 'exists')
),
'Department' => array(
'uid' => 'DEP_UID',
'fields' => array('DEPO_TITLE'),
'alias' => array('DEPO_TITLE' => 'DEP_TITLE'),
'methods' => array('exists' => 'existsDepartment')
),
'Task' => array(
'uid' => 'TAS_UID',
'fields' => array('TAS_TITLE', 'TAS_DESCRIPTION', 'TAS_DEF_TITLE', 'TAS_DEF_SUBJECT_MESSAGE', 'TAS_DEF_PROC_CODE', 'TAS_DEF_MESSAGE', 'TAS_DEF_DESCRIPTION'),
'methods' => array('exists' => 'taskExists')
),
'InputDocument' => array(
'uid' => 'INP_DOC_UID',
'fields' => array('INP_DOC_TITLE', 'INP_DOC_DESCRIPTION'),
'methods' => array('exists' => 'InputExists')
),
'Application' => array(
'uid' => 'APP_UID',
'fields' => array('APP_TITLE', 'APP_DESCRIPTION'),
'methods' => array('exists' => 'exists')
)
);
CLI::logging("-> Regenerating content \n");
foreach ($content as $className => $fields) {
$workspace->migrateContent($className, $fields, $workspace->name);
}
}

View File

@@ -121,6 +121,12 @@ class workspaceTools
$this->processFilesUpgrade(); $this->processFilesUpgrade();
$stop = microtime(true); $stop = microtime(true);
CLI::logging("<*> Updating Files Manager took " . ($stop - $start) . " seconds.\n"); CLI::logging("<*> Updating Files Manager took " . ($stop - $start) . " seconds.\n");
$start = microtime(true);
CLI::logging("> Optimizing content data...\n");
$this->migrateContent($workSpace, $lang);
$stop = microtime(true);
CLI::logging("<*> Optimizing content data took " . ($stop - $start) . " seconds.\n");
} }
/** /**
@@ -3099,21 +3105,37 @@ class workspaceTools
} }
return $response; return $response;
} }
public function migrateContent($workspace, $lang = SYS_LANG) {
if ((!class_exists('Memcache') || !class_exists('Memcached')) && !defined('MEMCACHED_ENABLED')) {
define('MEMCACHED_ENABLED', false);
}
$this->initPropel(true);
$conf = new Configuration();
if (!$conf->exists('MIGRATED_CONTENT', 'content')) {
$data["CFG_UID"] ='MIGRATED_CONTENT';
$data["OBJ_UID"] ='content';
$data["CFG_VALUE"]='true';
$data["PRO_UID"] ='';
$data["USR_UID"] ='';
$data["APP_UID"] ='';
$this->migrateContentRun($workspace, $lang);
$conf->create($data);
}
}
/** /**
* Migrate this workspace table Content. * Migrate this workspace table Content.
* *
* @param $className * @param $className
* @param $fields * @param $fields
* @param $workSpace * @param mixed|string $lang
* @param mixed|string $sys_lang
* @throws Exception * @throws Exception
*/ */
public function migrateContent($className, $fields, $workSpace, $sys_lang = SYS_LANG) public function migrateContentWorkspace($className, $fields, $lang = SYS_LANG)
{ {
try { try {
$this->initPropel(true); $this->initPropel(true);
$_SESSION['sys_sys'] = $workSpace;
$fieldUidName = $fields['uid']; $fieldUidName = $fields['uid'];
$oCriteria = new Criteria(); $oCriteria = new Criteria();
$oCriteria->clearSelectColumns(); $oCriteria->clearSelectColumns();
@@ -3121,7 +3143,7 @@ class workspaceTools
$oCriteria->addSelectColumn(ContentPeer::CON_CATEGORY); $oCriteria->addSelectColumn(ContentPeer::CON_CATEGORY);
$oCriteria->addSelectColumn(ContentPeer::CON_VALUE); $oCriteria->addSelectColumn(ContentPeer::CON_VALUE);
$oCriteria->add(ContentPeer::CON_CATEGORY, $fields['fields'], Criteria::IN); $oCriteria->add(ContentPeer::CON_CATEGORY, $fields['fields'], Criteria::IN);
$oCriteria->add(ContentPeer::CON_LANG, $sys_lang); $oCriteria->add(ContentPeer::CON_LANG, $lang);
$oDataset = ContentPeer::doSelectRS($oCriteria); $oDataset = ContentPeer::doSelectRS($oCriteria);
$oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC); $oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);
$methods = $fields['methods']; $methods = $fields['methods'];
@@ -3140,9 +3162,51 @@ class workspaceTools
} }
} }
$classNamePeer = $className . 'Peer'; $classNamePeer = $className . 'Peer';
CLI::logging("|--> Add content in table " . $classNamePeer::TABLE_NAME . "\n"); CLI::logging("|--> Add content data in table " . $classNamePeer::TABLE_NAME . "\n");
} catch (Exception $e) { } catch (Exception $e) {
throw ($e); throw ($e);
} }
} }
public function migrateContentRun($workspace, $lang = SYS_LANG) {
if ((!class_exists('Memcache') || !class_exists('Memcached')) && !defined('MEMCACHED_ENABLED')) {
define('MEMCACHED_ENABLED', false);
}
$content = array(
'Groupwf' => array(
'uid' => 'GRP_UID',
'fields' => array('GRP_TITLE'),
'methods' => array('exists' => 'GroupwfExists')
),
'Process' => array(
'uid' => 'PRO_UID',
'fields' => array('PRO_TITLE', 'PRO_DESCRIPTION'),
'methods' => array('exists' => 'exists')
),
'Department' => array(
'uid' => 'DEP_UID',
'fields' => array('DEPO_TITLE'),
'alias' => array('DEPO_TITLE' => 'DEP_TITLE'),
'methods' => array('exists' => 'existsDepartment')
),
'Task' => array(
'uid' => 'TAS_UID',
'fields' => array('TAS_TITLE', 'TAS_DESCRIPTION', 'TAS_DEF_TITLE', 'TAS_DEF_SUBJECT_MESSAGE', 'TAS_DEF_PROC_CODE', 'TAS_DEF_MESSAGE', 'TAS_DEF_DESCRIPTION'),
'methods' => array('exists' => 'taskExists')
),
'InputDocument' => array(
'uid' => 'INP_DOC_UID',
'fields' => array('INP_DOC_TITLE', 'INP_DOC_DESCRIPTION'),
'methods' => array('exists' => 'InputExists')
),
'Application' => array(
'uid' => 'APP_UID',
'fields' => array('APP_TITLE', 'APP_DESCRIPTION'),
'methods' => array('exists' => 'exists')
)
);
foreach ($content as $className => $fields) {
$this->migrateContentWorkspace($className, $fields, $lang);
}
}
} }