luos/workflow/engine/controllers/caseSchedulerProxy.php

<?php

use ProcessMaker\Core\System;
use ProcessMaker\Plugins\PluginRegistry;

class caseSchedulerProxy extends HttpProxyController
{

    function load ($params)
    {
        require_once "classes/model/Event.php";
        $PRO_UID = $params->PRO_UID;
        $EVN_UID = $params->EVN_UID;

        $oEvent = new Event();
        $oData = $oEvent->load( $EVN_UID );
        $sch_uid = $oData['EVN_ACTION'];

        if ($sch_uid != '') {
            $oProcessMap = new ProcessMap();
            $rows = $oProcessMap->caseNewSchedulerList( $sch_uid );
            if ($rows['SCH_OPTION'] == '3') {
                $sch_start_day = explode( '|', $rows['SCH_START_DAY'] );
                $count = count( $sch_start_day );
                switch ($count) {
                    case 1:
                        $rows['SCH_START_DAY'] = $sch_start_day[0];
                        break;
                    case 2:
                        $rows['SCH_START_DAY'] = $sch_start_day[0];
                        $rows['SCH_START_DAY_OPT_2_WEEKS'] = $sch_start_day[1];
                        break;
                    case 3:
                        $rows['SCH_START_DAY'] = $sch_start_day[0];
                        $rows['SCH_START_DAY_OPT_2_WEEKS'] = $sch_start_day[1];
                        $rows['SCH_START_DAY_OPT_2_DAYS_WEEK'] = $sch_start_day[2];
                        break;
                }
            }
            if ($rows['SCH_START_DATE'] != '') {
                $sch_str_dt = explode( ' ', $rows['SCH_START_DATE'] );
                $rows['SCH_START_DATE'] = $sch_str_dt[0];
            }
            if ($rows['SCH_END_DATE'] != '') {
                $sch_str_dt = explode( ' ', $rows['SCH_END_DATE'] );
                $rows['SCH_END_DATE'] = $sch_str_dt[0];
            }
            $this->success = true;
            $this->data = $rows;
        } else {
            $this->success = false;
        }
    }

    function delete ($params)
    {
        require_once 'classes/model/CaseScheduler.php';
        require_once 'classes/model/Event.php';
        $SCH_UID = $params->SCH_UID;
        $EVN_UID = $params->EVN_UID;
        $oCaseScheduler = new CaseScheduler();
        $oCaseScheduler->remove( $SCH_UID );
        $oEvent = new Event();
        $editE = array ();
        $editE['EVN_UID'] = $EVN_UID;
        $editE['EVN_ACTION'] = '';
        $oEvent->update( $editE );

        $this->success = true;
        $this->msg = G::LoadTranslation( 'ID_SCHEDULER_SUCCESS_DELETE' );
    }

    function changeStatus ($params)
    {
        require_once 'classes/model/CaseScheduler.php';
        $SCH_UID = $params->SCH_UID;
        $oCaseScheduler = new CaseScheduler();
        $oCaseScheduler->changeStatus( $SCH_UID );
        $oCaseScheduler->load( $SCH_UID );
        $this->success = true;
        $this->SCH_STATUS = $oCaseScheduler->getSchState();
        $this->msg = G::LoadTranslation( 'ID_SCHEDULER_SUCCESS_CHANGE_STATUS' );
    }

    function checkCredentials ($params)
    {
        require_once 'classes/model/Event.php';
        require_once 'classes/model/Users.php';
        require_once 'classes/model/TaskUser.php';
        require_once 'classes/model/GroupUser.php';
        $sPRO_UID = $params->PRO_UID;
        $sEVN_UID = $params->EVN_UID;
        $sWS_USER = trim( $params->WS_USER );
        $sWS_PASS = trim( $params->WS_PASS );

        $endpoint = System::getServerMainPath() . '/services/wsdl2';
        @$client = new SoapClient( $endpoint );

        $user = $sWS_USER;
        $pass = $sWS_PASS;

        $parameters = array ('userid' => $user,'password' => $pass
        );
        $result = $client->__SoapCall( 'login', array ($parameters
        ) );

        $fields['status_code'] = $result->status_code;
        $fields['message'] = 'ProcessMaker WebService version: ' . $result->version . "\n" . $result->message;
        $fields['version'] = $result->version;
        $fields['time_stamp'] = $result->timestamp;
        $messageCode = true;
        $message = $result->message;



        $event = new Event();
        $event->load( $sEVN_UID );
        $sTASKS = $event->getEvnTasUidTo();

        $task = new Task();
        $task->load( $sTASKS );
        $sTASKS_SEL = $task->getTasTitle();

        // if the user has been authenticated, then check if has the rights or
        // permissions to create the webentry
        if ($result->status_code == 0) {
            $oCriteria = new Criteria( 'workflow' );
            $oCriteria->addSelectColumn( UsersPeer::USR_UID );
            $oCriteria->addSelectColumn( TaskUserPeer::USR_UID );
            $oCriteria->addSelectColumn( TaskUserPeer::TAS_UID );
            $oCriteria->addJoin( TaskUserPeer::USR_UID, UsersPeer::USR_UID, Criteria::LEFT_JOIN );
            $oCriteria->add( TaskUserPeer::TAS_UID, $sTASKS );
            $oCriteria->add( UsersPeer::USR_USERNAME, $sWS_USER );
            //$oCriteria->add(TaskUserPeer::TU_RELATION,1);
            $userIsAssigned = TaskUserPeer::doCount( $oCriteria );
            // if the user is not assigned directly, maybe a have the task a group with the user
            if ($userIsAssigned < 1) {
                $oCriteria = new Criteria( 'workflow' );
                $oCriteria->addSelectColumn( UsersPeer::USR_UID );
                $oCriteria->addJoin( UsersPeer::USR_UID, GroupUserPeer::USR_UID, Criteria::LEFT_JOIN );
                $oCriteria->addJoin( GroupUserPeer::GRP_UID, TaskUserPeer::USR_UID, Criteria::LEFT_JOIN );
                $oCriteria->add( TaskUserPeer::TAS_UID, $sTASKS );
                $oCriteria->add( UsersPeer::USR_USERNAME, $sWS_USER );
                $userIsAssigned = GroupUserPeer::doCount( $oCriteria );
                if (! ($userIsAssigned >= 1)) {
                    $messageCode = false;
                    $message = "The User \"" . $sWS_USER . "\" doesn't have the task \"" . $sTASKS_SEL . "\" assigned.";
                }
            }

        } else {
            $messageCode = false;
        }

        $this->success = $messageCode;
        $this->msg = $message;
    }

    function save ($params)
    {
        require_once 'classes/model/CaseScheduler.php';
        $oCaseScheduler = new CaseScheduler();

        $aData['SCH_UID'] = G::generateUniqueID();
        $aData['SCH_NAME'] = $params->fDescription; //$_POST['form']['SCH_NAME'];
        $aData['SCH_DEL_USER_NAME'] = $params->fUser; //$_POST['form']['SCH_USER_NAME'];
        $aData['SCH_DEL_USER_PASS'] = G::encryptOld( $params->fPassword );
        $aData['SCH_DEL_USER_UID'] = $params->usr_uid; //$_POST['form']['SCH_USER_UID'];
        $aData['PRO_UID'] = $params->pro_uid; //$_POST['form']['PRO_UID'];
        $aData['TAS_UID'] = $params->tas_uid; //$_POST['form']['TAS_UID'];


        $aData['SCH_STATE'] = 'ACTIVE';
        $aData['SCH_LAST_STATE'] = 'CREATED'; // 'ACTIVE';
        $aData['USR_UID'] = $_SESSION['USER_LOGGED'];

        $sOption = $params->fType; //$_POST['form']['SCH_OPTION'];

        switch ($sOption) {
            case 'Daily':
                $sOption = '1';
                break;
            case 'Weekly':
                $sOption = '2';
                break;
            case 'Monthly':
                $sOption = '3';
                break;
            default:
                $sOption = '4';
                break;
        }

        $aData['SCH_OPTION'] = $sOption;

        //    if ($_POST['form']['SCH_START_DATE']!=''){
        //      $sDateTmp = $_POST['form']['SCH_START_DATE'];
        //    } else {
        //      $sDateTmp = date('Y-m-d');
        //    }


        $sDateTmp = $params->SCH_START_DATE;
        $sTimeTmp = $params->SCH_START_TIME; //$_POST['form']['SCH_START_TIME'];


        $aData['SCH_START_TIME'] = date( 'Y-m-d', strtotime( $sDateTmp ) ) . ' ' . date( 'H:i:s', strtotime( $sTimeTmp ) );
        $aData['SCH_START_DATE'] = date( 'Y-m-d', strtotime( $sDateTmp ) ) . ' ' . date( 'H:i:s', strtotime( $sTimeTmp ) );

        //g::pr($aData);


        $nActualTime = $sTimeTmp; //date("Y-m-d  H:i:s"); // time();
        //$nActualDate = date("Y-m-d  H:i:s");


        $sValue = '';
        $sDaysPerformTask = '';
        $sWeeks = '';
        $sMonths = '';
        $sMonths = '';
        $sStartDay = '';
        $nSW = 0;

        switch ($sOption) {
            case '1': // Option 1
                $sValue = isset( $params->SCH_DAYS_PERFORM_TASK ) ? $params->SCH_DAYS_PERFORM_TASK : '1'; //$_POST['form']['SCH_DAYS_PERFORM_TASK'];
                switch ($sValue) {
                    case '1':
                        $aData['SCH_DAYS_PERFORM_TASK'] = $sValue . '|1';
                        break;
                    case '2':
                        $aData['SCH_OPTION'] = '2';
                        $aData['SCH_EVERY_DAYS'] = '1';
                        $aData['SCH_WEEK_DAYS'] = '1|2|3|4|5|';
                        break;
                    case '3': // Every [n] Days
                        $sDaysPerformTask = $params->SCH_DAYS_PERFORM_TASK_OPT_3;
                        $aData['SCH_DAYS_PERFORM_TASK'] = $params->SCH_DAYS_PERFORM_TASK . '|' . $params->SCH_DAYS_PERFORM_TASK_OPT_3;
                        break;
                }
                break;
            case '2': // If the option is zero, set by default 1
                $sWeeks = '';
                if (isset( $params->W1 )) {
                    if ($sWeeks != '') {
                        $sWeeks .= '|';
                    }
                    $sWeeks .= '1';
                }
                if (isset( $params->W2 )) {
                    if ($sWeeks != '') {
                        $sWeeks .= '|';
                    }
                    $sWeeks .= '2';
                }
                if (isset( $params->W3 )) {
                    if ($sWeeks != '') {
                        $sWeeks .= '|';
                    }
                    $sWeeks .= '3';
                }
                if (isset( $params->W4 )) {
                    if ($sWeeks != '') {
                        $sWeeks .= '|';
                    }
                    $sWeeks .= '4';
                }
                if (isset( $params->W5 )) {
                    if ($sWeeks != '') {
                        $sWeeks .= '|';
                    }
                    $sWeeks .= '5';
                }
                if (isset( $params->W6 )) {
                    if ($sWeeks != '') {
                        $sWeeks .= '|';
                    }
                    $sWeeks .= '6';
                }
                if (isset( $params->W7 )) {
                    if ($sWeeks != '') {
                        $sWeeks .= '|';
                    }
                    $sWeeks .= '7';
                }
                $sStartTime = $params->SCH_START_TIME;
                $aData['SCH_WEEK_DAYS'] = $sWeeks;
                $aData['SCH_START_DAY'] = ''; //
                break;
            case '3':
                $nStartDay = $params->SCH_START_DAY;
                if ($nStartDay == 'Day of Month') {
                    $nStartDay = 1;
                }
                if ($nStartDay == 'The Day') {
                    $nStartDay = 2;
                }
                if ($nStartDay == 1) {
                    $aData['SCH_START_DAY'] = $nStartDay . '|' . $params->SCH_START_DAY_OPT_1;
                } else {
                    $opt2weeks = $params->SCH_START_DAY_OPT_2_WEEKS;
                    switch ($opt2weeks) {
                        case 'First':
                            $opt2weeks = 1;
                            break;
                        case 'Second':
                            $opt2weeks = 2;
                            break;
                        case 'Third':
                            $opt2weeks = 3;
                            break;
                        case 'Fourth':
                            $opt2weeks = 4;
                            break;
                        case 'Last':
                            $opt2weeks = 5;
                            break;
                    }
                    $opt2days = $params->SCH_START_DAY_OPT_2_DAYS_WEEK;
                    switch ($opt2days) {
                        case 'Monday':
                            $opt2days = 1;
                            break;
                        case 'Tuesday':
                            $opt2days = 2;
                            break;
                        case 'Wednesday':
                            $opt2days = 3;
                            break;
                        case 'Thursday':
                            $opt2days = 4;
                            break;
                        case 'Friday':
                            $opt2days = 5;
                            break;
                        case 'Saturday':
                            $opt2days = 6;
                            break;
                        case 'Sunday':
                            $opt2days = 7;
                            break;
                    }
                    $aData['SCH_START_DAY'] = $nStartDay . '|' . $opt2weeks . '|' . $opt2days;
                }

                $sMonths = '';
                if (isset( $params->M1 )) {
                    if ($sMonths != '') {
                        $sMonths .= '|';
                    }
                    $sMonths .= '1';
                }
                if (isset( $params->M2 )) {
                    if ($sMonths != '') {
                        $sMonths .= '|';
                    }
                    $sMonths .= '2';
                }
                if (isset( $params->M3 )) {
                    if ($sMonths != '') {
                        $sMonths .= '|';
                    }
                    $sMonths .= '3';
                }
                if (isset( $params->M4 )) {
                    if ($sMonths != '') {
                        $sMonths .= '|';
                    }
                    $sMonths .= '4';
                }
                if (isset( $params->M5 )) {
                    if ($sMonths != '') {
                        $sMonths .= '|';
                    }
                    $sMonths .= '5';
                }
                if (isset( $params->M6 )) {
                    if ($sMonths != '') {
                        $sMonths .= '|';
                    }
                    $sMonths .= '6';
                }
                if (isset( $params->M7 )) {
                    if ($sMonths != '') {
                        $sMonths .= '|';
                    }
                    $sMonths .= '7';
                }
                if (isset( $params->M8 )) {
                    if ($sMonths != '') {
                        $sMonths .= '|';
                    }
                    $sMonths .= '8';
                }
                if (isset( $params->M9 )) {
                    if ($sMonths != '') {
                        $sMonths .= '|';
                    }
                    $sMonths .= '9';
                }
                if (isset( $params->M10 )) {
                    if ($sMonths != '') {
                        $sMonths .= '|';
                    }
                    $sMonths .= '10';
                }
                if (isset( $params->M11 )) {
                    if ($sMonths != '') {
                        $sMonths .= '|';
                    }
                    $sMonths .= '11';
                }
                if (isset( $params->M12 )) {
                    if ($sMonths != '') {
                        $sMonths .= '|';
                    }
                    $sMonths .= '12';
                }
                //        if(!empty($params->SCH_MONTHS)){
                //          $aMonths = $params->SCH_MONTHS;
                //          foreach($aMonths as $value) {
                //            $sMonths = $sMonths . $value . '|' ;
                //          }
                //        }
                //        if(!empty($params->SCH_MONTHS_2)){
                //          $aMonths2 = $params->SCH_MONTHS_2;
                //          foreach($aMonths2 as $value) {
                //            $sMonths = $sMonths . $value . '|' ;
                //          }
                //        }
                //        if(!empty($params->SCH_MONTHS_3)){
                //          $aMonths3 = $params->SCH_MONTHS_3;
                //          foreach($aMonths3 as $value) {
                //            $sMonths = $sMonths . $value . '|' ;
                //          }
                //        }
                $aData['SCH_MONTHS'] = $sMonths;
                $sStartDay = $aData['SCH_START_DAY'];
                $sValue = $nStartDay;
                break;

        }
        if (($sOption != '1') && ($sOption != '4')) {
            if ($sStartDay == '') {
                $sStartDay = date( 'Y-m-d' );
            }
            //                echo $sOption."*". $sValue."*". $nActualTime."*". $sDaysPerformTask."*". $sWeeks."*". $sStartDay ."*". $sMonths."<br>";
            $dCurrentDay = date( "d" );
            $dCurrentMonth = date( "m" );
            $aStartDay = explode( "|", $aData['SCH_START_DAY'] );
            if ($sOption == '3' && $aStartDay[0] == '1') {
                $monthsArray = explode( "|", $sMonths );
                foreach ($monthsArray as $row) {
                    if ($dCurrentMonth == $row && $dCurrentDay < $aStartDay[1]) {
                        $startTime = $params->SCH_START_TIME . ":00";
                        $aData['SCH_TIME_NEXT_RUN'] = date( 'Y' ) . '-' . $row . '-' . $aStartDay[1] . ' ' . $startTime;
                        break;
                    } else {
                        $aData['SCH_TIME_NEXT_RUN'] = $oCaseScheduler->updateNextRun( $sOption, $sValue, $nActualTime, $sDaysPerformTask, $sWeeks, $sStartDay, $sMonths, $sDateTmp );
                    }
                }
            } else {
                $aData['SCH_TIME_NEXT_RUN'] = $oCaseScheduler->updateNextRun( $sOption, $sValue, $nActualTime, $sDaysPerformTask, $sWeeks, $sStartDay, $sMonths, $sDateTmp );
            }
            //                print_r ($aData['SCH_TIME_NEXT_RUN']);
            //                die;
        } else {
            if ($sOption == '4') {
                $aData['SCH_END_DATE'] = $aData['SCH_START_TIME'];
            }
            $aData['SCH_TIME_NEXT_RUN'] = $aData['SCH_START_TIME'];
        }

        if (isset( $params->SCH_END_DATE )) {
            if (trim( $params->SCH_END_DATE ) != '') {
                $aData['SCH_END_DATE'] = $params->SCH_END_DATE;
            }
        }

        if (! empty( $params->SCH_REPEAT_TASK_CHK )) {
            $nOptEvery = $params->SCH_REPEAT_EVERY_OPT;
            if ($nOptEvery == 2) {
                $aData['SCH_REPEAT_EVERY'] = $params->SCH_REPEAT_EVERY_OPT * 60;
            } else {
                $aData['SCH_REPEAT_EVERY'] = $params->SCH_REPEAT_EVERY_OPT;
            }
        }

        if ((isset( $_POST['form']['CASE_SH_PLUGIN_UID'] )) && ($_POST['form']['CASE_SH_PLUGIN_UID'] != "")) {
            $aData['CASE_SH_PLUGIN_UID'] = $_POST['form']['CASE_SH_PLUGIN_UID'];
        }
        //$aData['SCH_END_DATE'] = "2020-12-30";
        //g::pr($aData);
        $sch_uid = $params->sch_uid;
        if ($sch_uid != '') {
            $aData['SCH_UID'] = $sch_uid;
            $oCaseScheduler->Update( $aData );
            $sw_update = true;
        } else {
            $oCaseScheduler->create( $aData );
            $sch_uid = $oCaseScheduler->getSchUid();
            $sw_update = false;
        }

        if ((isset( $_POST['form']['CASE_SH_PLUGIN_UID'] )) && ($_POST['form']['CASE_SH_PLUGIN_UID'] != "")) {
            $params = explode( "--", $_REQUEST['form']['CASE_SH_PLUGIN_UID'] );
            $oPluginRegistry = PluginRegistry::loadSingleton();
            $activePluginsForCaseScheduler = $oPluginRegistry->getCaseSchedulerPlugins();
            /** @var \ProcessMaker\Plugins\Interfaces\CaseSchedulerPlugin $caseSchedulerPluginDetail */
            foreach ($activePluginsForCaseScheduler as $caseSchedulerPluginDetail) {
                if (($caseSchedulerPluginDetail->equalNamespaceTo($params[0])) && ($caseSchedulerPluginDetail->equalActionIdTo($params[1]))) {
                    $caseSchedulerSelected = $caseSchedulerPluginDetail;
                }
            }
            if ((isset( $caseSchedulerSelected )) && (is_object( $caseSchedulerSelected ))) {
                //Save the form
                $oData = $_POST['pluginFields'];
                $oData['SCH_UID'] = $aData['SCH_UID'];
                $oPluginRegistry->executeMethod( $caseSchedulerPluginDetail->getNamespace(), $caseSchedulerPluginDetail->getActionSave(), $oData );
            }
        }

        //Added by Qennix
        //Update Start Time Event in BPMN
        require_once 'classes/model/Event.php';
        require_once 'classes/model/Task.php';

        $oTask = new Task();
        $oTask->load( $params->tas_uid );
        $evn_uid = $oTask->getStartingEvent();
        $tas_name = $oTask->getTasTitle();
        $event = new Event();
        $editEvent = array ();
        $editEvent['EVN_UID'] = $evn_uid;
        $editEvent['EVN_ACTION'] = $sch_uid;
        $event->update( $editEvent );
        //End Adding


        $sch = new CaseScheduler();
        $sch->load( $sch_uid );

        $this->success = true;
        $this->SCH_UID = $sch_uid;
        $this->NEXT = $sch->getSchTimeNextRun();
        $this->DESCRIPTION = $sch->getSchName();
        $this->TAS_NAME = $tas_name;
        if ($sw_update) {
            $this->msg = G::LoadTranslation( 'ID_SCHEDULER_SUCCESS_UPDATE' );
        } else {
            $this->msg = G::LoadTranslation( 'ID_SCHEDULER_SUCCESS_NEW' );
        }
    }

    function loadCS ($params)
    {
        require_once 'classes/model/CaseScheduler.php';
        $SCH_UID = $params->SCH_UID;
        $oCaseScheduler = new CaseScheduler();
        $data = $oCaseScheduler->load( $SCH_UID );
        $start_date = $data['SCH_START_DATE'];
        $start_date = date( 'Y-m-d', strtotime( $start_date ) );
        $data['START_DATE'] = $start_date;
        $end_date = $data['SCH_END_DATE'];
        if ($end_date != '') {
            $end_date = date( 'Y-m-d', strtotime( $end_date ) );
        }
        $data['END_DATE'] = $end_date;
        $exec_time = $data['SCH_START_TIME'];
        $exec_time = date( 'H:i', strtotime( $exec_time ) );
        $data['EXEC_TIME'] = $exec_time;

        $weeks = $data['SCH_WEEK_DAYS'];
        $week = explode( '|', $weeks );
        $w1 = $w2 = $w3 = $w4 = $w5 = $w6 = $w7 = false;
        foreach ($week as $w) {
            switch ($w) {
                case 1:
                    $w1 = true;
                    break;
                case 2:
                    $w2 = true;
                    break;
                case 3:
                    $w3 = true;
                    break;
                case 4:
                    $w4 = true;
                    break;
                case 5:
                    $w5 = true;
                    break;
                case 6:
                    $w6 = true;
                    break;
                case 7:
                    $w7 = true;
                    break;
            }
        }
        $data['W1'] = $w1;
        $data['W2'] = $w2;
        $data['W3'] = $w3;
        $data['W4'] = $w4;
        $data['W5'] = $w5;
        $data['W6'] = $w6;
        $data['W7'] = $w7;

        $years = $data['SCH_MONTHS'];
        $year = explode( '|', $years );
        $m1 = $m2 = $m3 = $m4 = $m5 = $m6 = $m7 = $m8 = $m9 = $m10 = $m11 = $m12 = false;
        foreach ($year as $month) {
            switch ($month) {
                case 1:
                    $m1 = true;
                    break;
                case 2:
                    $m2 = true;
                    break;
                case 3:
                    $m3 = true;
                    break;
                case 4:
                    $m4 = true;
                    break;
                case 5:
                    $m5 = true;
                    break;
                case 6:
                    $m6 = true;
                    break;
                case 7:
                    $m7 = true;
                    break;
                case 8:
                    $m8 = true;
                    break;
                case 9:
                    $m9 = true;
                    break;
                case 10:
                    $m10 = true;
                    break;
                case 11:
                    $m11 = true;
                    break;
                case 12:
                    $m12 = true;
                    break;
            }
        }

        $data['M1'] = $m1;
        $data['M2'] = $m2;
        $data['M3'] = $m3;
        $data['M4'] = $m4;
        $data['M5'] = $m5;
        $data['M6'] = $m6;
        $data['M7'] = $m7;
        $data['M8'] = $m8;
        $data['M9'] = $m9;
        $data['M10'] = $m10;
        $data['M11'] = $m11;
        $data['M12'] = $m12;

        $start_options = $data['SCH_START_DAY'];
        $options = explode( '|', $start_options );
        $data['TYPE_CMB'] = $options[0];
        if ($options[0] == 1) {
            $data['EACH_DAY'] = $options[1];
        } else {
            $data['CMB_1'] = $options[1];
            $data['CMB_2'] = $options[2];
        }
        $this->success = true;
        $this->data = $data;
    }

} //End caseSchedulerProxy