workflow_schema.inc

<?php
require_once SQ_CORE_PACKAGE_PATH.'/folder/folder.inc';

class Workflow_Schema extends Folder
{


    function __construct($assetid=0)
    {
        parent::__construct($assetid);

    }//end constructor



    protected function _createAdditional(Array &$link)
    {
        $ok = TRUE;

        $GLOBALS['SQ_SYSTEM']->am->includeAsset('workflow_stream');
        $new_stream = new Workflow_Stream();
        $new_stream->setAttrValue('name', 'Default Stream');

        $link_info = Array(
                        'asset'         => $this,
                        'link_type'     => SQ_LINK_TYPE_2,
                        'value'         => 'default_stream',
                        'is_exclusive'  => TRUE,
                        'is_dependant'  => FALSE,
                     );

        if (!$new_stream->create($link_info)) {
            $ok = FALSE;
            break;
        }

        return $ok;

    }//end _createAdditional()


    public function lockTypes()
    {
        $lock_types = parent::lockTypes();
        $lock_types['content'] = ($lock_types['attributes'] | $lock_types['links']);
        return $lock_types;

    }//end lockTypes()


    public function _getAllowedLinks()
    {
        return Array(
                SQ_LINK_TYPE_1  => Array(),
                SQ_LINK_TYPE_2  => Array(
                                    'workflow_stream'   => Array(
                                                            'card'      => 'M',
                                                            'exclusive' => FALSE,
                                                           ),
                                    'workflow_step'     => Array(
                                                            'card'      => 'M',
                                                            'exclusive' => FALSE,
                                                           ),
                                   ),
                SQ_LINK_TYPE_3  => Array(),
                SQ_LINK_NOTICE  => Array(),
               );

    }//end _getAllowedLinks()


    public function prepareLink(Asset $asset, $side_of_link, &$link_type, &$value, &$sort_order, &$dependant, &$exclusive)
    {
        // if this is a workflow step then we need to make it a dependant link
        if ($side_of_link == 'major' && ($asset instanceof Workflow_Stream) && $dependant != '1') {
            $dependant = '1';
            return TRUE;
        }

        return FALSE;

    }//end prepareLink()


    public function saveWebPaths(Array $paths)
    {
        return TRUE;

    }//end saveWebPaths()


    public function delete($release_lock=TRUE, $check_locked=TRUE)
    {
        // lets have with us all the assets the schema we are deleteing is applied to
        $wfm = $GLOBALS['SQ_SYSTEM']->getWorkflowManager();
        $schema_treeids_sql = 'SELECT
                                assetid, granted, wflow
                                FROM (sq_ast_lnk_tree ta
                                    JOIN sq_ast_lnk la ON ta.linkid = la.linkid
                                        JOIN sq_ast_wflow wa ON la.minorid = wa.assetid)
                                WHERE wa.schemaid = :schemaid
                                AND NOT EXISTS (
                                    SELECT * FROM (sq_ast_lnk_tree tb
                                                    JOIN sq_ast_lnk lb ON tb.linkid = lb.linkid
                                                        JOIN sq_ast_wflow wb ON lb.minorid = wb.assetid)
                                    WHERE wb.schemaid = wa.schemaid
                                    AND length(ta.treeid) - LENGTH(tb.treeid) = :tree_size 
                                    AND SUBSTR(ta.treeid, 1, LENGTH(ta.treeid) - :tree_size_1) = tb.treeid
                                    AND wa.granted = wb.granted
                                    AND wa.cascades = wb.cascades
                                ) ORDER BY assetid';

        $query = MatrixDAL::preparePdoQuery($schema_treeids_sql);
        MatrixDAL::bindValueToPdo($query, 'schemaid', $this->id);
        MatrixDAL::bindValueToPdo($query, 'tree_size', SQ_CONF_ASSET_TREE_SIZE);
        MatrixDAL::bindValueToPdo($query, 'tree_size_1', SQ_CONF_ASSET_TREE_SIZE);
        $results = MatrixDAL::executePdoAssoc($query);

        // check for running schema
        $running_schema = FALSE;
        $running_id = array();
        foreach ($results as $index => $info) {
            if(!empty($info['wflow'])) {
            $running_schema = TRUE;
            $running_id[] = $info['assetid'];
            }
        }
        if($running_schema) {
            trigger_error('Purged Workflow Schema Id #'.$this->id.' is applied and running on assets with Id: '.  implode(', ', $running_id), E_USER_NOTICE);
            return FALSE;
        }
        
        // guess what? someone is deleting schema even when it might be applied to assets.
        // lets be smart and remove from the assets where schema is NOT running
        foreach ($results as $index => $info) {
            if(empty($info['wflow'])) {
                $GLOBALS['SQ_SYSTEM']->setRunLevel(SQ_RUN_LEVEL_FORCED);
                    $wfm->deleteSchema($info['assetid'], $this->id);
                $GLOBALS['SQ_SYSTEM']->restoreRunLevel();
            } else {
                // oops someone is deleting the workflow without considering that it might
                // be running on some assets.
                trigger_error('Purged Workflow Schema Id #'.$this->id.' is applied and running on Asset Id #'.$info['assetid'].'.', E_USER_NOTICE);
                return FALSE;
            }
        }

        // we have now removed the db entries removed...all set to delete the schema
        if(!parent::delete($release_lock, $check_locked)) {
            return FALSE;
        }

        return TRUE;

    }//end delete()


}//end class

?>