Improve ifs
Remove PRO_ID update because it is not required Refresh APP_STATUS_ID
This commit is contained in:
@@ -7,6 +7,7 @@ EOT
|
||||
CLI::taskOpt("lang", "", "lLANG", "lang=LANG");
|
||||
CLI::taskArg('workspace');
|
||||
CLI::taskRun("list_ids");
|
||||
G::LoadClass("wsTools");
|
||||
|
||||
function list_ids($command, $args)
|
||||
{
|
||||
@@ -25,39 +26,11 @@ function list_ids($command, $args)
|
||||
$workspace->dbInfo['DB_USER'],
|
||||
$workspace->dbInfo['DB_PASS']
|
||||
);
|
||||
$dbh->query('UPDATE LIST_CANCELED SET '
|
||||
. 'USR_ID=(SELECT USR_ID FROM USERS WHERE USERS.USR_UID=LIST_CANCELED.USR_UID), '
|
||||
. 'TAS_ID=(SELECT TAS_ID FROM TASK WHERE TASK.TAS_UID=LIST_CANCELED.TAS_UID), '
|
||||
. 'PRO_ID=(SELECT PRO_ID FROM PROCESS WHERE PROCESS.PRO_UID=LIST_CANCELED.PRO_UID);');
|
||||
$dbh->query('UPDATE LIST_COMPLETED SET '
|
||||
. 'USR_ID=(SELECT USR_ID FROM USERS WHERE USERS.USR_UID=LIST_COMPLETED.USR_UID), '
|
||||
. 'TAS_ID=(SELECT TAS_ID FROM TASK WHERE TASK.TAS_UID=LIST_COMPLETED.TAS_UID), '
|
||||
. 'PRO_ID=(SELECT PRO_ID FROM PROCESS WHERE PROCESS.PRO_UID=LIST_COMPLETED.PRO_UID);');
|
||||
$dbh->query('UPDATE LIST_INBOX SET '
|
||||
. 'USR_ID=(SELECT USR_ID FROM USERS WHERE USERS.USR_UID=LIST_INBOX.USR_UID), '
|
||||
. 'TAS_ID=(SELECT TAS_ID FROM TASK WHERE TASK.TAS_UID=LIST_INBOX.TAS_UID), '
|
||||
. 'PRO_ID=(SELECT PRO_ID FROM PROCESS WHERE PROCESS.PRO_UID=LIST_INBOX.PRO_UID);');
|
||||
$dbh->query('UPDATE LIST_MY_INBOX SET '
|
||||
. 'USR_ID=(SELECT USR_ID FROM USERS WHERE USERS.USR_UID=LIST_MY_INBOX.USR_UID), '
|
||||
. 'TAS_ID=(SELECT TAS_ID FROM TASK WHERE TASK.TAS_UID=LIST_MY_INBOX.TAS_UID), '
|
||||
. 'PRO_ID=(SELECT PRO_ID FROM PROCESS WHERE PROCESS.PRO_UID=LIST_MY_INBOX.PRO_UID);');
|
||||
$dbh->query('UPDATE LIST_PARTICIPATED_HISTORY SET '
|
||||
. 'USR_ID=(SELECT USR_ID FROM USERS WHERE USERS.USR_UID=LIST_PARTICIPATED_HISTORY.USR_UID), '
|
||||
. 'TAS_ID=(SELECT TAS_ID FROM TASK WHERE TASK.TAS_UID=LIST_PARTICIPATED_HISTORY.TAS_UID), '
|
||||
. 'PRO_ID=(SELECT PRO_ID FROM PROCESS WHERE PROCESS.PRO_UID=LIST_PARTICIPATED_HISTORY.PRO_UID);');
|
||||
$dbh->query('UPDATE LIST_PARTICIPATED_LAST SET '
|
||||
. 'USR_ID=(SELECT USR_ID FROM USERS WHERE USERS.USR_UID=LIST_PARTICIPATED_LAST.USR_UID), '
|
||||
. 'TAS_ID=(SELECT TAS_ID FROM TASK WHERE TASK.TAS_UID=LIST_PARTICIPATED_LAST.TAS_UID), '
|
||||
. 'PRO_ID=(SELECT PRO_ID FROM PROCESS WHERE PROCESS.PRO_UID=LIST_PARTICIPATED_LAST.PRO_UID);');
|
||||
$dbh->query('UPDATE LIST_PAUSED SET '
|
||||
. 'USR_ID=(SELECT USR_ID FROM USERS WHERE USERS.USR_UID=LIST_PAUSED.USR_UID), '
|
||||
. 'TAS_ID=(SELECT TAS_ID FROM TASK WHERE TASK.TAS_UID=LIST_PAUSED.TAS_UID), '
|
||||
. 'PRO_ID=(SELECT PRO_ID FROM PROCESS WHERE PROCESS.PRO_UID=LIST_PAUSED.PRO_UID);');
|
||||
$dbh->query('UPDATE LIST_UNASSIGNED SET '
|
||||
. 'TAS_ID=(SELECT TAS_ID FROM TASK WHERE TASK.TAS_UID=LIST_UNASSIGNED.TAS_UID), '
|
||||
. 'PRO_ID=(SELECT PRO_ID FROM PROCESS WHERE PROCESS.PRO_UID=LIST_UNASSIGNED.PRO_UID);');
|
||||
$dbh->query('UPDATE LIST_UNASSIGNED_GROUP SET '
|
||||
. 'USR_ID=(SELECT USR_ID FROM USERS WHERE USERS.USR_UID=LIST_UNASSIGNED_GROUP.USR_UID);');
|
||||
foreach(workspaceTools::$populateIdsQueries as $query) {
|
||||
echo ".";
|
||||
$dbh->query($query);
|
||||
}
|
||||
echo "\n";
|
||||
}
|
||||
|
||||
//Done
|
||||
|
||||
@@ -24,6 +24,41 @@ class workspaceTools
|
||||
public $dbInfoRegExp = "/( *define *\( *'(?P<key>.*?)' *, *\n* *')(?P<value>.*?)(' *\) *;.*)/";
|
||||
public $initPropel = false;
|
||||
public $initPropelRoot = false;
|
||||
public static $populateIdsQueries = [
|
||||
'UPDATE LIST_CANCELED SET '
|
||||
. 'USR_ID=(SELECT USR_ID FROM USERS WHERE USERS.USR_UID=LIST_CANCELED.USR_UID),'
|
||||
. 'TAS_ID=(SELECT TAS_ID FROM TASK WHERE TASK.TAS_UID=LIST_CANCELED.TAS_UID), '
|
||||
. 'PRO_ID=(SELECT PRO_ID FROM PROCESS WHERE PROCESS.PRO_UID=LIST_CANCELED.PRO_UID)',
|
||||
'UPDATE LIST_COMPLETED SET '
|
||||
. 'USR_ID=(SELECT USR_ID FROM USERS WHERE USERS.USR_UID=LIST_COMPLETED.USR_UID),'
|
||||
. 'TAS_ID=(SELECT TAS_ID FROM TASK WHERE TASK.TAS_UID=LIST_COMPLETED.TAS_UID), '
|
||||
. 'PRO_ID=(SELECT PRO_ID FROM PROCESS WHERE PROCESS.PRO_UID=LIST_COMPLETED.PRO_UID)',
|
||||
'UPDATE LIST_INBOX SET '
|
||||
. 'USR_ID=(SELECT USR_ID FROM USERS WHERE USERS.USR_UID=LIST_INBOX.USR_UID),'
|
||||
. 'TAS_ID=(SELECT TAS_ID FROM TASK WHERE TASK.TAS_UID=LIST_INBOX.TAS_UID), '
|
||||
. 'PRO_ID=(SELECT PRO_ID FROM PROCESS WHERE PROCESS.PRO_UID=LIST_INBOX.PRO_UID)',
|
||||
'UPDATE LIST_MY_INBOX SET '
|
||||
. 'USR_ID=(SELECT USR_ID FROM USERS WHERE USERS.USR_UID=LIST_MY_INBOX.USR_UID),'
|
||||
. 'TAS_ID=(SELECT TAS_ID FROM TASK WHERE TASK.TAS_UID=LIST_MY_INBOX.TAS_UID),'
|
||||
. 'PRO_ID=(SELECT PRO_ID FROM PROCESS WHERE PROCESS.PRO_UID=LIST_MY_INBOX.PRO_UID)',
|
||||
'UPDATE LIST_PARTICIPATED_HISTORY SET '
|
||||
. 'USR_ID=(SELECT USR_ID FROM USERS WHERE USERS.USR_UID=LIST_PARTICIPATED_HISTORY.USR_UID),'
|
||||
. 'TAS_ID=(SELECT TAS_ID FROM TASK WHERE TASK.TAS_UID=LIST_PARTICIPATED_HISTORY.TAS_UID), '
|
||||
. 'PRO_ID=(SELECT PRO_ID FROM PROCESS WHERE PROCESS.PRO_UID=LIST_PARTICIPATED_HISTORY.PRO_UID)',
|
||||
'UPDATE LIST_PARTICIPATED_LAST SET '
|
||||
. 'USR_ID=(SELECT USR_ID FROM USERS WHERE USERS.USR_UID=LIST_PARTICIPATED_LAST.USR_UID),'
|
||||
. 'TAS_ID=(SELECT TAS_ID FROM TASK WHERE TASK.TAS_UID=LIST_PARTICIPATED_LAST.TAS_UID), '
|
||||
. 'PRO_ID=(SELECT PRO_ID FROM PROCESS WHERE PROCESS.PRO_UID=LIST_PARTICIPATED_LAST.PRO_UID)',
|
||||
'UPDATE LIST_PAUSED SET '
|
||||
. 'USR_ID=(SELECT USR_ID FROM USERS WHERE USERS.USR_UID=LIST_PAUSED.USR_UID),'
|
||||
. 'TAS_ID=(SELECT TAS_ID FROM TASK WHERE TASK.TAS_UID=LIST_PAUSED.TAS_UID),'
|
||||
. 'PRO_ID=(SELECT PRO_ID FROM PROCESS WHERE PROCESS.PRO_UID=LIST_PAUSED.PRO_UID)',
|
||||
'UPDATE LIST_UNASSIGNED SET '
|
||||
. 'TAS_ID=(SELECT TAS_ID FROM TASK WHERE TASK.TAS_UID=LIST_UNASSIGNED.TAS_UID), '
|
||||
. 'PRO_ID=(SELECT PRO_ID FROM PROCESS WHERE PROCESS.PRO_UID=LIST_UNASSIGNED.PRO_UID)',
|
||||
'UPDATE LIST_UNASSIGNED_GROUP SET '
|
||||
. 'USR_ID=(SELECT USR_ID FROM USERS WHERE USERS.USR_UID=LIST_UNASSIGNED_GROUP.USR_UID)',
|
||||
];
|
||||
|
||||
/**
|
||||
* Create a workspace tools object.
|
||||
@@ -3636,39 +3671,9 @@ class workspaceTools
|
||||
CLI::logging("-> Populating PRO_ID, USR_ID at LIST_* \n");
|
||||
$con->begin();
|
||||
$stmt = $con->createStatement();
|
||||
$stmt->executeQuery('UPDATE LIST_CANCELED SET '
|
||||
. 'USR_ID=(SELECT USR_ID FROM USERS WHERE USERS.USR_UID=LIST_CANCELED.USR_UID),'
|
||||
. 'TAS_ID=(SELECT TAS_ID FROM TASK WHERE TASK.TAS_UID=LIST_CANCELED.TAS_UID), '
|
||||
. 'PRO_ID=(SELECT PRO_ID FROM PROCESS WHERE PROCESS.PRO_UID=LIST_CANCELED.PRO_UID)');
|
||||
$stmt->executeQuery('UPDATE LIST_COMPLETED SET '
|
||||
. 'USR_ID=(SELECT USR_ID FROM USERS WHERE USERS.USR_UID=LIST_COMPLETED.USR_UID),'
|
||||
. 'TAS_ID=(SELECT TAS_ID FROM TASK WHERE TASK.TAS_UID=LIST_COMPLETED.TAS_UID), '
|
||||
. 'PRO_ID=(SELECT PRO_ID FROM PROCESS WHERE PROCESS.PRO_UID=LIST_COMPLETED.PRO_UID)');
|
||||
$stmt->executeQuery('UPDATE LIST_INBOX SET '
|
||||
. 'USR_ID=(SELECT USR_ID FROM USERS WHERE USERS.USR_UID=LIST_INBOX.USR_UID),'
|
||||
. 'TAS_ID=(SELECT TAS_ID FROM TASK WHERE TASK.TAS_UID=LIST_INBOX.TAS_UID), '
|
||||
. 'PRO_ID=(SELECT PRO_ID FROM PROCESS WHERE PROCESS.PRO_UID=LIST_INBOX.PRO_UID)');
|
||||
$stmt->executeQuery('UPDATE LIST_MY_INBOX SET '
|
||||
. 'USR_ID=(SELECT USR_ID FROM USERS WHERE USERS.USR_UID=LIST_MY_INBOX.USR_UID),'
|
||||
. 'TAS_ID=(SELECT TAS_ID FROM TASK WHERE TASK.TAS_UID=LIST_MY_INBOX.TAS_UID),'
|
||||
. 'PRO_ID=(SELECT PRO_ID FROM PROCESS WHERE PROCESS.PRO_UID=LIST_MY_INBOX.PRO_UID)');
|
||||
$stmt->executeQuery('UPDATE LIST_PARTICIPATED_HISTORY SET '
|
||||
. 'USR_ID=(SELECT USR_ID FROM USERS WHERE USERS.USR_UID=LIST_PARTICIPATED_HISTORY.USR_UID),'
|
||||
. 'TAS_ID=(SELECT TAS_ID FROM TASK WHERE TASK.TAS_UID=LIST_PARTICIPATED_HISTORY.TAS_UID), '
|
||||
. 'PRO_ID=(SELECT PRO_ID FROM PROCESS WHERE PROCESS.PRO_UID=LIST_PARTICIPATED_HISTORY.PRO_UID)');
|
||||
$stmt->executeQuery('UPDATE LIST_PARTICIPATED_LAST SET '
|
||||
. 'USR_ID=(SELECT USR_ID FROM USERS WHERE USERS.USR_UID=LIST_PARTICIPATED_LAST.USR_UID),'
|
||||
. 'TAS_ID=(SELECT TAS_ID FROM TASK WHERE TASK.TAS_UID=LIST_PARTICIPATED_LAST.TAS_UID), '
|
||||
. 'PRO_ID=(SELECT PRO_ID FROM PROCESS WHERE PROCESS.PRO_UID=LIST_PARTICIPATED_LAST.PRO_UID)');
|
||||
$stmt->executeQuery('UPDATE LIST_PAUSED SET '
|
||||
. 'USR_ID=(SELECT USR_ID FROM USERS WHERE USERS.USR_UID=LIST_PAUSED.USR_UID),'
|
||||
. 'TAS_ID=(SELECT TAS_ID FROM TASK WHERE TASK.TAS_UID=LIST_PAUSED.TAS_UID),'
|
||||
. 'PRO_ID=(SELECT PRO_ID FROM PROCESS WHERE PROCESS.PRO_UID=LIST_PAUSED.PRO_UID)');
|
||||
$stmt->executeQuery('UPDATE LIST_UNASSIGNED SET '
|
||||
. 'TAS_ID=(SELECT TAS_ID FROM TASK WHERE TASK.TAS_UID=LIST_UNASSIGNED.TAS_UID), '
|
||||
. 'PRO_ID=(SELECT PRO_ID FROM PROCESS WHERE PROCESS.PRO_UID=LIST_UNASSIGNED.PRO_UID)');
|
||||
$stmt->executeQuery('UPDATE LIST_UNASSIGNED_GROUP SET '
|
||||
. 'USR_ID=(SELECT USR_ID FROM USERS WHERE USERS.USR_UID=LIST_UNASSIGNED_GROUP.USR_UID)');
|
||||
foreach(workspaceTools::$populateIdsQueries as $query) {
|
||||
$stmt->executeQuery($query);
|
||||
}
|
||||
$con->commit();
|
||||
|
||||
CLI::logging("-> Populating PRO_ID, USR_ID at LIST_* Done \n");
|
||||
|
||||
@@ -105,16 +105,16 @@ class ListCanceled extends BaseListCanceled {
|
||||
$criteriaSet->add(ListParticipatedLastPeer::APP_STATUS, 'CANCELLED');
|
||||
BasePeer::doUpdate($criteriaWhere, $criteriaSet, Propel::getConnection("workflow"));
|
||||
|
||||
$p = new Process();
|
||||
if (!empty($data['PRO_UID'])) {
|
||||
$p = new Process();
|
||||
$data['PRO_ID'] = $p->load($data['PRO_UID'])['PRO_ID'];
|
||||
}
|
||||
$u = new Users();
|
||||
if (!empty($data['USR_UID'])) {
|
||||
$data['USR_ID'] = $data['USR_UID']==='SELF_SERVICES' ? null : $u->load($data['USR_UID'])['USR_ID'];
|
||||
$u = new Users();
|
||||
$data['USR_ID'] = $u->load($data['USR_UID'])['USR_ID'];
|
||||
}
|
||||
$t = new Task();
|
||||
if (!empty($data['TAS_UID'])) {
|
||||
$t = new Task();
|
||||
$data['TAS_ID'] = $t->load($data['TAS_UID'])['TAS_ID'];
|
||||
}
|
||||
$con = Propel::getConnection( ListCanceledPeer::DATABASE_NAME );
|
||||
@@ -144,16 +144,12 @@ class ListCanceled extends BaseListCanceled {
|
||||
*/
|
||||
public function update($data)
|
||||
{
|
||||
$p = new Process();
|
||||
if (!empty($data['PRO_UID'])) {
|
||||
$data['PRO_ID'] = $p->load($data['PRO_UID'])['PRO_ID'];
|
||||
}
|
||||
$u = new Users();
|
||||
if (!empty($data['USR_UID'])) {
|
||||
$data['USR_ID'] = $data['USR_UID']==='SELF_SERVICES' ? null : $u->load($data['USR_UID'])['USR_ID'];
|
||||
$u = new Users();
|
||||
$data['USR_ID'] = $u->load($data['USR_UID'])['USR_ID'];
|
||||
}
|
||||
$t = new Task();
|
||||
if (!empty($data['TAS_UID'])) {
|
||||
$t = new Task();
|
||||
$data['TAS_ID'] = $t->load($data['TAS_UID'])['TAS_ID'];
|
||||
}
|
||||
$con = Propel::getConnection( ListCanceledPeer::DATABASE_NAME );
|
||||
|
||||
@@ -97,16 +97,16 @@ class ListCompleted extends BaseListCompleted
|
||||
$criteriaSet->add(ListParticipatedLastPeer::APP_STATUS, 'COMPLETED');
|
||||
BasePeer::doUpdate($criteriaWhere, $criteriaSet, Propel::getConnection("workflow"));
|
||||
|
||||
$p = new Process();
|
||||
if (!empty($data['PRO_UID'])) {
|
||||
$p = new Process();
|
||||
$data['PRO_ID'] = $p->load($data['PRO_UID'])['PRO_ID'];
|
||||
}
|
||||
$u = new Users();
|
||||
if (!empty($data['USR_UID'])) {
|
||||
$data['USR_ID'] = $data['USR_UID']==='SELF_SERVICES' ? null : $u->load($data['USR_UID'])['USR_ID'];
|
||||
$u = new Users();
|
||||
$data['USR_ID'] = $u->load($data['USR_UID'])['USR_ID'];
|
||||
}
|
||||
$t = new Task();
|
||||
if (!empty($data['TAS_UID'])) {
|
||||
$t = new Task();
|
||||
$data['TAS_ID'] = $t->load($data['TAS_UID'])['TAS_ID'];
|
||||
}
|
||||
$con = Propel::getConnection( ListCompletedPeer::DATABASE_NAME );
|
||||
@@ -136,16 +136,12 @@ class ListCompleted extends BaseListCompleted
|
||||
*/
|
||||
public function update($data)
|
||||
{
|
||||
$p = new Process();
|
||||
if (!empty($data['PRO_UID'])) {
|
||||
$data['PRO_ID'] = $p->load($data['PRO_UID'])['PRO_ID'];
|
||||
}
|
||||
$u = new Users();
|
||||
if (!empty($data['USR_UID'])) {
|
||||
$data['USR_ID'] = $data['USR_UID']==='SELF_SERVICES' ? null : $u->load($data['USR_UID'])['USR_ID'];
|
||||
$u = new Users();
|
||||
$data['USR_ID'] = $u->load($data['USR_UID'])['USR_ID'];
|
||||
}
|
||||
$t = new Task();
|
||||
if (!empty($data['TAS_UID'])) {
|
||||
$t = new Task();
|
||||
$data['TAS_ID'] = $t->load($data['TAS_UID'])['TAS_ID'];
|
||||
}
|
||||
$con = Propel::getConnection( ListCompletedPeer::DATABASE_NAME );
|
||||
|
||||
@@ -32,18 +32,21 @@ class ListInbox extends BaseListInbox
|
||||
$aData = $oCase->loadCase( $data["APP_UID"] );
|
||||
$data['APP_TITLE'] = G::replaceDataField($data['APP_TITLE'], $aData['APP_DATA']);
|
||||
}
|
||||
$p = new Process();
|
||||
if (!empty($data['PRO_UID'])) {
|
||||
$p = new Process();
|
||||
$data['PRO_ID'] = $p->load($data['PRO_UID'])['PRO_ID'];
|
||||
}
|
||||
$u = new Users();
|
||||
if (!empty($data['USR_UID'])) {
|
||||
$u = new Users();
|
||||
$data['USR_ID'] = $data['USR_UID']==='SELF_SERVICES' ? null : $u->load($data['USR_UID'])['USR_ID'];
|
||||
}
|
||||
$t = new Task();
|
||||
if (!empty($data['TAS_UID'])) {
|
||||
$t = new Task();
|
||||
$data['TAS_ID'] = $t->load($data['TAS_UID'])['TAS_ID'];
|
||||
}
|
||||
if (!empty($data['APP_STATUS'])) {
|
||||
$data['APP_STATUS_ID'] = Application::$app_status_values[$data['APP_STATUS']];
|
||||
}
|
||||
$this->fromArray( $data, BasePeer::TYPE_FIELDNAME );
|
||||
if ($this->validate()) {
|
||||
$result = $this->save();
|
||||
@@ -158,18 +161,17 @@ class ListInbox extends BaseListInbox
|
||||
$data['DEL_PRIORITY'] = $this->getTaskPriority($data['TAS_UID'], $data['PRO_UID'], $data["APP_UID"]);
|
||||
}
|
||||
|
||||
$p = new Process();
|
||||
if (!empty($data['PRO_UID'])) {
|
||||
$data['PRO_ID'] = $p->load($data['PRO_UID'])['PRO_ID'];
|
||||
}
|
||||
$u = new Users();
|
||||
if (!empty($data['USR_UID'])) {
|
||||
$u = new Users();
|
||||
$data['USR_ID'] = $data['USR_UID']==='SELF_SERVICES' ? null : $u->load($data['USR_UID'])['USR_ID'];
|
||||
}
|
||||
$t = new Task();
|
||||
if (!empty($data['TAS_UID'])) {
|
||||
$t = new Task();
|
||||
$data['TAS_ID'] = $t->load($data['TAS_UID'])['TAS_ID'];
|
||||
}
|
||||
if (!empty($data['APP_STATUS'])) {
|
||||
$data['APP_STATUS_ID'] = Application::$app_status_values[$data['APP_STATUS']];
|
||||
}
|
||||
$con = Propel::getConnection( ListInboxPeer::DATABASE_NAME );
|
||||
try {
|
||||
$con->begin();
|
||||
|
||||
@@ -25,18 +25,21 @@ class ListMyInbox extends BaseListMyInbox
|
||||
*/
|
||||
public function create($data)
|
||||
{
|
||||
$p = new Process();
|
||||
if (!empty($data['PRO_UID'])) {
|
||||
$p = new Process();
|
||||
$data['PRO_ID'] = $p->load($data['PRO_UID'])['PRO_ID'];
|
||||
}
|
||||
$u = new Users();
|
||||
if (!empty($data['USR_UID'])) {
|
||||
$data['USR_ID'] = $data['USR_UID']==='SELF_SERVICES' ? null : $u->load($data['USR_UID'])['USR_ID'];
|
||||
$u = new Users();
|
||||
$data['USR_ID'] = $u->load($data['USR_UID'])['USR_ID'];
|
||||
}
|
||||
$t = new Task();
|
||||
if (!empty($data['TAS_UID'])) {
|
||||
$t = new Task();
|
||||
$data['TAS_ID'] = $t->load($data['TAS_UID'])['TAS_ID'];
|
||||
}
|
||||
if (!empty($data['APP_STATUS'])) {
|
||||
$data['APP_STATUS_ID'] = Application::$app_status_values[$data['APP_STATUS']];
|
||||
}
|
||||
$con = Propel::getConnection( ListMyInboxPeer::DATABASE_NAME );
|
||||
try {
|
||||
$this->fromArray( $data, BasePeer::TYPE_FIELDNAME );
|
||||
@@ -64,18 +67,17 @@ class ListMyInbox extends BaseListMyInbox
|
||||
*/
|
||||
public function update($data)
|
||||
{
|
||||
$p = new Process();
|
||||
if(!empty($data['PRO_UID'])) {
|
||||
$data['PRO_ID'] = $p->load($data['PRO_UID'])['PRO_ID'];
|
||||
}
|
||||
$u = new Users();
|
||||
if(!empty($data['USR_UID'])) {
|
||||
$data['USR_ID'] = $data['USR_UID']==='SELF_SERVICES' ? null : $u->load($data['USR_UID'])['USR_ID'];
|
||||
$u = new Users();
|
||||
$data['USR_ID'] = $u->load($data['USR_UID'])['USR_ID'];
|
||||
}
|
||||
$t = new Task();
|
||||
if (!empty($data['TAS_UID'])) {
|
||||
$t = new Task();
|
||||
$data['TAS_ID'] = $t->load($data['TAS_UID'])['TAS_ID'];
|
||||
}
|
||||
if (!empty($data['APP_STATUS'])) {
|
||||
$data['APP_STATUS_ID'] = Application::$app_status_values[$data['APP_STATUS']];
|
||||
}
|
||||
$con = Propel::getConnection( ListMyInboxPeer::DATABASE_NAME );
|
||||
try {
|
||||
$con->begin();
|
||||
|
||||
@@ -25,16 +25,16 @@ class ListParticipatedHistory extends BaseListParticipatedHistory
|
||||
*/
|
||||
public function create($data)
|
||||
{
|
||||
$p = new Process();
|
||||
if(!empty($data['PRO_UID'])) {
|
||||
$p = new Process();
|
||||
$data['PRO_ID'] = $p->load($data['PRO_UID'])['PRO_ID'];
|
||||
}
|
||||
$u = new Users();
|
||||
if(!empty($data['USR_UID'])) {
|
||||
$data['USR_ID'] = $data['USR_UID']==='SELF_SERVICES' ? null : $u->load($data['USR_UID'])['USR_ID'];
|
||||
$u = new Users();
|
||||
$data['USR_ID'] = $u->load($data['USR_UID'])['USR_ID'];
|
||||
}
|
||||
$t = new Task();
|
||||
if (!empty($data['TAS_UID'])) {
|
||||
$t = new Task();
|
||||
$data['TAS_ID'] = $t->load($data['TAS_UID'])['TAS_ID'];
|
||||
}
|
||||
$con = Propel::getConnection( ListParticipatedHistoryPeer::DATABASE_NAME );
|
||||
@@ -64,16 +64,12 @@ class ListParticipatedHistory extends BaseListParticipatedHistory
|
||||
*/
|
||||
public function update($data)
|
||||
{
|
||||
$p = new Process();
|
||||
if(!empty($data['PRO_UID'])) {
|
||||
$data['PRO_ID'] = $p->load($data['PRO_UID'])['PRO_ID'];
|
||||
}
|
||||
$u = new Users();
|
||||
if(!empty($data['USR_UID'])) {
|
||||
$data['USR_ID'] = $data['USR_UID']==='SELF_SERVICES' ? null : $u->load($data['USR_UID'])['USR_ID'];
|
||||
$u = new Users();
|
||||
$data['USR_ID'] = $u->load($data['USR_UID'])['USR_ID'];
|
||||
}
|
||||
$t = new Task();
|
||||
if (!empty($data['TAS_UID'])) {
|
||||
$t = new Task();
|
||||
$data['TAS_ID'] = $t->load($data['TAS_UID'])['TAS_ID'];
|
||||
}
|
||||
$con = Propel::getConnection( ListParticipatedHistoryPeer::DATABASE_NAME );
|
||||
|
||||
@@ -70,18 +70,21 @@ class ListParticipatedLast extends BaseListParticipatedLast
|
||||
return;
|
||||
}
|
||||
|
||||
$p = new Process();
|
||||
if(!empty($data['PRO_UID'])) {
|
||||
$p = new Process();
|
||||
$data['PRO_ID'] = $p->load($data['PRO_UID'])['PRO_ID'];
|
||||
}
|
||||
$u = new Users();
|
||||
if(!empty($data['USR_UID'])) {
|
||||
$data['USR_ID'] = $data['USR_UID']==='SELF_SERVICES' ? null : $u->load($data['USR_UID'])['USR_ID'];
|
||||
$u = new Users();
|
||||
$data['USR_ID'] = $u->load($data['USR_UID'])['USR_ID'];
|
||||
}
|
||||
$t = new Task();
|
||||
if (!empty($data['TAS_UID'])) {
|
||||
$t = new Task();
|
||||
$data['TAS_ID'] = $t->load($data['TAS_UID'])['TAS_ID'];
|
||||
}
|
||||
if (!empty($data['APP_STATUS'])) {
|
||||
$data['APP_STATUS_ID'] = Application::$app_status_values[$data['APP_STATUS']];
|
||||
}
|
||||
$con = Propel::getConnection( ListParticipatedLastPeer::DATABASE_NAME );
|
||||
try {
|
||||
$this->fromArray( $data, BasePeer::TYPE_FIELDNAME );
|
||||
@@ -110,18 +113,17 @@ class ListParticipatedLast extends BaseListParticipatedLast
|
||||
public function update($data)
|
||||
{
|
||||
$data['DEL_THREAD_STATUS'] = (isset($data['DEL_THREAD_STATUS'])) ? $data['DEL_THREAD_STATUS'] : 'OPEN';
|
||||
$p = new Process();
|
||||
if(!empty($data['PRO_UID'])) {
|
||||
$data['PRO_ID'] = $p->load($data['PRO_UID'])['PRO_ID'];
|
||||
}
|
||||
$u = new Users();
|
||||
if(!empty($data['USR_UID'])) {
|
||||
$u = new Users();
|
||||
$data['USR_ID'] = $data['USR_UID']==='SELF_SERVICES' ? null : $u->load($data['USR_UID'])['USR_ID'];
|
||||
}
|
||||
$t = new Task();
|
||||
if (!empty($data['TAS_UID'])) {
|
||||
$t = new Task();
|
||||
$data['TAS_ID'] = $t->load($data['TAS_UID'])['TAS_ID'];
|
||||
}
|
||||
if (!empty($data['APP_STATUS'])) {
|
||||
$data['APP_STATUS_ID'] = Application::$app_status_values[$data['APP_STATUS']];
|
||||
}
|
||||
$con = Propel::getConnection( ListParticipatedLastPeer::DATABASE_NAME );
|
||||
try {
|
||||
$con->begin();
|
||||
@@ -151,6 +153,17 @@ class ListParticipatedLast extends BaseListParticipatedLast
|
||||
public function refresh ($data, $isSelfService = false)
|
||||
{
|
||||
$data['APP_STATUS'] = (empty($data['APP_STATUS'])) ? 'TO_DO' : $data['APP_STATUS'];
|
||||
if(!empty($data['USR_UID'])) {
|
||||
$u = new Users();
|
||||
$data['USR_ID'] = $data['USR_UID']==='SELF_SERVICES' ? null : $u->load($data['USR_UID'])['USR_ID'];
|
||||
}
|
||||
if (!empty($data['TAS_UID'])) {
|
||||
$t = new Task();
|
||||
$data['TAS_ID'] = $t->load($data['TAS_UID'])['TAS_ID'];
|
||||
}
|
||||
if (!empty($data['APP_STATUS'])) {
|
||||
$data['APP_STATUS_ID'] = Application::$app_status_values[$data['APP_STATUS']];
|
||||
}
|
||||
if (!$isSelfService) {
|
||||
if ($data["USR_UID"] == "") {
|
||||
return;
|
||||
|
||||
@@ -114,13 +114,17 @@ class ListPaused extends BaseListPaused {
|
||||
$oListInbox = new ListInbox();
|
||||
$oListInbox->remove($data['APP_UID'], $data['DEL_INDEX']);
|
||||
|
||||
$p = new Process();
|
||||
if(!empty($data['PRO_UID'])) {
|
||||
$p = new Process();
|
||||
$data['PRO_ID'] = $p->load($data['PRO_UID'])['PRO_ID'];
|
||||
}
|
||||
$u = new Users();
|
||||
if(!empty($data['USR_UID'])) {
|
||||
$data['USR_ID'] = $data['USR_UID']==='SELF_SERVICES' ? null : $u->load($data['USR_UID'])['USR_ID'];
|
||||
$u = new Users();
|
||||
$data['USR_ID'] = $u->load($data['USR_UID'])['USR_ID'];
|
||||
}
|
||||
if (!empty($data['TAS_UID'])) {
|
||||
$t = new Task();
|
||||
$data['TAS_ID'] = $t->load($data['TAS_UID'])['TAS_ID'];
|
||||
}
|
||||
$con = Propel::getConnection( ListPausedPeer::DATABASE_NAME );
|
||||
try {
|
||||
@@ -149,13 +153,13 @@ class ListPaused extends BaseListPaused {
|
||||
*/
|
||||
public function update($data)
|
||||
{
|
||||
$p = new Process();
|
||||
if(!empty($data['PRO_UID'])) {
|
||||
$data['PRO_ID'] = $p->load($data['PRO_UID'])['PRO_ID'];
|
||||
}
|
||||
$u = new Users();
|
||||
if(!empty($data['USR_UID'])) {
|
||||
$data['USR_ID'] = $data['USR_UID']==='SELF_SERVICES' ? null : $u->load($data['USR_UID'])['USR_ID'];
|
||||
$u = new Users();
|
||||
$data['USR_ID'] = $u->load($data['USR_UID'])['USR_ID'];
|
||||
}
|
||||
if (!empty($data['TAS_UID'])) {
|
||||
$t = new Task();
|
||||
$data['TAS_ID'] = $t->load($data['TAS_UID'])['TAS_ID'];
|
||||
}
|
||||
$con = Propel::getConnection( ListPausedPeer::DATABASE_NAME );
|
||||
try {
|
||||
|
||||
@@ -26,12 +26,12 @@ class ListUnassigned extends BaseListUnassigned
|
||||
*/
|
||||
public function create($data)
|
||||
{
|
||||
$p = new Process();
|
||||
if(!empty($data['PRO_UID'])) {
|
||||
$p = new Process();
|
||||
$data['PRO_ID'] = $p->load($data['PRO_UID'])['PRO_ID'];
|
||||
}
|
||||
$t = new Task();
|
||||
if (!empty($data['TAS_UID'])) {
|
||||
$t = new Task();
|
||||
$data['TAS_ID'] = $t->load($data['TAS_UID'])['TAS_ID'];
|
||||
}
|
||||
$con = Propel::getConnection( ListUnassignedPeer::DATABASE_NAME );
|
||||
@@ -61,12 +61,8 @@ class ListUnassigned extends BaseListUnassigned
|
||||
*/
|
||||
public function update($data)
|
||||
{
|
||||
$p = new Process();
|
||||
if(!empty($data['PRO_UID'])) {
|
||||
$data['PRO_ID'] = $p->load($data['PRO_UID'])['PRO_ID'];
|
||||
}
|
||||
$t = new Task();
|
||||
if (!empty($data['TAS_UID'])) {
|
||||
$t = new Task();
|
||||
$data['TAS_ID'] = $t->load($data['TAS_UID'])['TAS_ID'];
|
||||
}
|
||||
$con = Propel::getConnection( ListUnassignedPeer::DATABASE_NAME );
|
||||
|
||||
@@ -24,9 +24,9 @@ class ListUnassignedGroup extends BaseListUnassignedGroup {
|
||||
*/
|
||||
public function create($data)
|
||||
{
|
||||
$u = new Users();
|
||||
if(!empty($data['USR_UID'])) {
|
||||
$data['USR_ID'] = $data['USR_UID']==='SELF_SERVICES' ? null : $u->load($data['USR_UID'])['USR_ID'];
|
||||
$u = new Users();
|
||||
$data['USR_ID'] = $u->load($data['USR_UID'])['USR_ID'];
|
||||
}
|
||||
$con = Propel::getConnection( ListUnassignedGroupPeer::DATABASE_NAME );
|
||||
try {
|
||||
@@ -54,9 +54,9 @@ class ListUnassignedGroup extends BaseListUnassignedGroup {
|
||||
*/
|
||||
public function update($data)
|
||||
{
|
||||
$u = new Users();
|
||||
if(!empty($data['USR_UID'])) {
|
||||
$data['USR_ID'] = $data['USR_UID']==='SELF_SERVICES' ? null : $u->load($data['USR_UID'])['USR_ID'];
|
||||
$u = new Users();
|
||||
$data['USR_ID'] = $u->load($data['USR_UID'])['USR_ID'];
|
||||
}
|
||||
$con = Propel::getConnection( ListUnassignedGroupPeer::DATABASE_NAME );
|
||||
try {
|
||||
|
||||
Reference in New Issue
Block a user