luos/workflow/engine/classes/model/DashletInstance.php

<?php

require_once 'classes/model/om/BaseDashletInstance.php';


/**
 * Skeleton subclass for representing a row from the 'DASHLET_INSTANCE' table.
 *
 *
 *
 * You should add additional methods to this class to meet the
 * application requirements.  This class will only be generated as
 * long as it does not already exist in the output directory.
 *
 * @package    classes.model
 */
class DashletInstance extends BaseDashletInstance
{
    private $filterThisFields = array('DAS_INS_UID', 'DAS_UID', 'DAS_INS_OWNER_TYPE', 'DAS_INS_OWNER_UID',
                                    'DAS_INS_CREATE_DATE', 'DAS_INS_UPDATE_DATE', 'DAS_INS_STATUS',
                                    "pm_sys_sys", "ys-admin-tabpanel", "PHPSESSID");

    public function load($dasInsUid)
    {
        try {
            $dashletInstance = DashletInstancePeer::retrieveByPK($dasInsUid);
            $fields = $dashletInstance->toArray(BasePeer::TYPE_FIELDNAME);
            if ($fields['DAS_INS_ADDITIONAL_PROPERTIES'] != '') {
                $fields = array_merge($fields, unserialize($fields['DAS_INS_ADDITIONAL_PROPERTIES']));
            }
            return $fields;
        } catch (Exception $error) {
            throw $error;
        }
    }

    public function createOrUpdate($data)
    {
        $additionalFields = array();
        foreach ($data as $field => $value) {
            if (!in_array($field, $this->filterThisFields)) {
                $additionalFields[$field] = $value;
                unset($data[$field]);
            }
        }

        $connection = Propel::getConnection(DashletInstancePeer::DATABASE_NAME);

        try {
            if (!isset($data['DAS_INS_UID'])) {
                $data['DAS_INS_UID'] = '';
            }
            if ($data['DAS_INS_UID'] == '') {
                $dashletInstance = new DashletInstance();

                $data['DAS_INS_UID'] = G::generateUniqueID();
                $data['DAS_INS_ADDITIONAL_PROPERTIES'] = (!empty($additionalFields))? serialize($additionalFields) : '';
                $data['DAS_INS_CREATE_DATE'] = date('Y-m-d H:i:s');

                $msg = 'CreateDashletInstance';
            } else {
                $dashletInstance = DashletInstancePeer::retrieveByPK($data['DAS_INS_UID']);

                if (!empty($additionalFields)) {
                    $arrayAdditionalProperties = [];

                    if ($dashletInstance->getDasInsAdditionalProperties() != '') {
                        $arrayAux = unserialize($dashletInstance->getDasInsAdditionalProperties());
                        $arrayAdditionalProperties = (is_array($arrayAux))? $arrayAux : $arrayAdditionalProperties;
                    }

                    $additionalFields = array_merge($arrayAdditionalProperties, $additionalFields);

                    $data['DAS_INS_ADDITIONAL_PROPERTIES'] = serialize($additionalFields);
                }

                $msg = 'UpdateDashletInstance';
            }
            $data['DAS_INS_UPDATE_DATE'] = date('Y-m-d H:i:s');
            $dashletInstance->fromArray($data, BasePeer::TYPE_FIELDNAME);
            if ($dashletInstance->validate()) {
                $connection->begin();
                $result = $dashletInstance->save();
                $connection->commit();

                $dashletData = $this->load($data['DAS_INS_UID']);
                G::auditLog($msg, "Dashlet Instance Name: ".$dashletData['DAS_INS_TITLE']." Dashlet Instance ID: (".$dashletData['DAS_INS_UID'].") ");

                return $data['DAS_INS_UID'];
            } else {
                $message = '';
                $validationFailures = $dashletInstance->getValidationFailures();
                foreach ($validationFailures as $validationFailure) {
                    $message .= $validationFailure->getMessage() . '. ';
                }
                throw(new Exception('Error trying to update: ' . $message));
            }
        } catch (Exception $error) {
            $connection->rollback();
            throw $error;
        }
    }

    public function remove($dasInsUid)
    {
        $connection = Propel::getConnection(DashletInstancePeer::DATABASE_NAME);
        try {
            $dashletInstance = DashletInstancePeer::retrieveByPK($dasInsUid);
            if (!is_null($dashletInstance)) {
                $connection->begin();
                $dashletData = $this->load($dasInsUid);
                $result = $dashletInstance->delete();
                $connection->commit();

                G::auditLog("DeleteDashletInstance", "Dashlet Instance Name: ". $dashletData['DAS_INS_TITLE']." Dashlet Instance ID: (".$dasInsUid.") ");
                return $result;
            } else {
                throw new Exception('Error trying to delete: The row "' .  $dasInsUid. '" does not exist.');
            }
        } catch (Exception $error) {
            $connection->rollback();
            throw $error;
        }
    }
}