Smopp_v2/functions.php

<?php

use CheckPoints\CheckPoint;
use CheckPointTypes\CheckPointType;
//use Tasks\Task;

require_once 'ocs.php';

$onlineMobileTimeoutSeconds = 600;

function VagrantRequest($accid, $tagid, $name, $eventtype, $echo=false)
{
    if ($tagid=='unavailable')
        return;
    global $link;
    $account = Account::Find($accid);
    $jobstring = "No role";
    if ($account)
    {
        $jobtypes = $account->getJobtypesIds();
        $jobstring = GetJobNames($jobtypes)[0];
        $company = $account->getCompany();
        if ($company)
        {
            if (intval($company->id) > 1)
                return;
        }
//        $jobnames_account = GetJobNames($jobtypes)[0];
//        $jobstring = implode(",", $jobnames_account);
    }
//    var_dump($jobstring);
//return;
    $params['projectId'] = "000T";
    $params['role'] = $jobstring;
    $params['fullName'] = $name; //"123";//"2019-10-28T13:00:00";
    $params['employeeId'] = $accid; //"123";//"2019-10-28T13:00:00";
    $params['tagId'] = $tagid; //"123";//"2019-10-28T13:00:00";
    $params['eventType'] = $eventtype; //1;//"2019-10-28T13:00:00";
    $url = "https://vagrantsmopp.azurewebsites.net/api/EmployeeTag";
    $jsonEncoded = json_encode($params);

    $curl = curl_init();

    curl_setopt($curl, CURLOPT_URL, $url);
    curl_setopt($curl, CURLOPT_HTTPHEADER, array("Content-Type: application/json", "Accept:application/json"));
    curl_setopt($curl, CURLOPT_TIMEOUT, 60);
    curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($curl, CURLOPT_FOLLOWLOCATION, true);
    curl_setopt($curl, CURLOPT_POST, 1);
    curl_setopt($curl, CURLOPT_POSTFIELDS, $jsonEncoded);
    curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
    curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);


    $result = curl_exec($curl);
    $str = "insert into vagrant_log (acc_id, eventtype, reply, stamp, tagid) values ($accid, $eventtype, '$result', NOW(), '$tagid')";
    mysqli_query($link, $str);

    if ($echo) {
        var_dump($result);
        var_dump($params);
//        echo $str;
    }



}


function GetCompanyID($act, $activeid)
{
    $companyID = 0;
    switch ($act)
    {
        case "tasktypes":
            $tt = Tasktype::Find($activeid);
            if ($tt)
                $companyID = $tt->company;
            break;
        case "tasks":
            $task = Task::Find($activeid);
            if ($task) {
                $type = $task->type;
                $tt = Tasktype::Find($type);
                if ($tt)
                    $companyID = $tt->company;
            }
            break;
        case "projects":
            $proj = Project::Find($activeid);
            if ($proj)
                $companyID = $proj->getCompany();
            break;
        case "project_types":
            $proj = ProjectType::Find($activeid);
            if ($proj)
                $companyID = $proj->company;
            break;
    }
    return $companyID;
}

function EnqueueCMD($acc_id, $cmd)
{
    global $link;

    $str = "insert into commands (account_id, cmd, created) values ($acc_id, '$cmd', NOW())";
    $query = mysqli_query($link, $str);
}

function DequeueCMD($acc_id)
{
    global $link;
    $str = "select * from commands where account_id = $acc_id";
    $query = mysqli_query($link, $str);
    $cmdarr = array();
    while ($res = mysqli_fetch_array($query)) {
        $cmd = $res['cmd'];
        array_push($cmdarr, $cmd);
        mysqli_query($link, "delete from commands where id = ".$res['id']);
    }
    return $cmdarr;
}

function XLSRead($inputFileName, $activeSheet = 0)
{
    error_reporting(E_ALL);
    set_time_limit(0);

    date_default_timezone_set('Europe/London');

    /** Include path **/
    set_include_path(get_include_path() . PATH_SEPARATOR . 'PHPExcel_1.8.0_doc/Classes/');

    /** PHPExcel_IOFactory */
    include 'PHPExcel/IOFactory.php';
    //$inputFileName = 'example1.xls';

    //$inputFileName = './sampleData/example1.xls';
//    echo 'Loading file ', pathinfo($inputFileName, PATHINFO_BASENAME), ' using IOFactory to identify the format<br />';
    $objPHPExcel = PHPExcel_IOFactory::load($inputFileName);


    echo '<hr />';
    if ($activeSheet > 0)
        $objPHPExcel->setActiveSheetIndex($activeSheet);
    $sheetData = $objPHPExcel->getActiveSheet()->toArray(null, true, true, true);
    //var_dump($sheetData);
    return $sheetData;
}

function FindAction($actionID)
{
    global $link, $companyID;
    $query1 = mysqli_query($link, "select * from projecttypes where id=$actionID");

    if ($res1 = mysqli_fetch_array($query1)) {
        return $res1;
    }
}

function FindActions($tasktype = '')
{
    global $link, $companyID, $entityManager;

    return $entityManager->getRepository('ProjectType')->findBy(array('company' => $companyID));
//    //return $entityManager->getRepository('MyProject\Domain\User')->findBy(array('age' => 20, 'surname' => 'Miller'));
//
//    $str = "select p_r.id,p_r.name,p_r.company
//                from projecttypes p_r
//                join projecttypes_tasktypes p_t on p_t.projecttype_id = p_r.id
//                join tasktypes t on t.id = p_t.tasktype_id
//                where p_r.company = $companyID" ;
//
////$str = "select * from project_types where company=$companyID";
//    if ($tasktype != '') {
//        //$str .= " and $tasktype in (tasktypes)";
//        $str .= " and t.id = $tasktype";
//    }
//    //var_dump($str); die();
//
//    $query1 = mysqli_query($link, $str);
//    $returnArr = array();
//    while ($res1 = mysqli_fetch_array($query1)) {
//        array_push($returnArr, $res1);
//    }
//
//    return $returnArr;
}

function FindParentTaskType($ttid)
{
    global $link;
    $str = "select * from tasktypes tt where main_task=1 and $ttid IN (tt.subtasks)";
    //echo '$str'.$str;
    $returnArr = array();
    $query1 = mysqli_query($link, $str);
    while ($res1 = mysqli_fetch_array($query1)) {
    
        array_push($returnArr, $res1);
    }
    return $returnArr;
}

function FindTaskOwner($tid)
{
    global $link;
    $str = "select id from accounts accs where $tid IN (accs.active_task_ids)";
//    echo '$str'.$str;
    $returnArr = array();
    $query1 = mysqli_query($link, $str);
    if ($res1 = mysqli_fetch_row($query1)) {
        return $res1[0];
    }
    return null;
//    while ($res1 = mysqli_fetch_array($query1)) {
//
//        array_push($returnArr, $res1);
//    }
//    return $returnArr;
}


function StartProject($action, $project_id, $manager=null)
{
    global $entityManager;
//    var_dump($entityManager);
//    echo "<br>"; die();
    //$assign_id - id таблицы входных данных
    //$action - действие (например перемещение)
    //данная функция:
    //1. ищет в базе среди tasktype данное действие (глобальное main_task=true)
    //2. создает задачу найденного типа
    $existing_tasks = GetTasksForProject($project_id);
    
    if (sizeof($existing_tasks) > 0) {
        echo "<span style='color: red'>Задачи для этого проекта уже созданы</span><br>";
        OCSnewproject($project_id);
        return true;
    }
//    $tasktypesarr = GrabTasktypes("all", intval($action));
    if ( null == $entityManager ) {
        $entityManager = $manager;
    }

    $tasktypesarr = ProjectType::GrabTasktypesByProjectType(intval($action), $entityManager);

    if (sizeof($tasktypesarr) > 0) {

        CreateTasks($tasktypesarr, $project_id);
        OCSnewproject($project_id);
        return true;
    }
    else
    {
        echo "<span style='color: red'>Ошибка: нет подходящих задач под выбранное действие</span>";
        OCSnewproject($project_id);
        return false;
    }
}

function getTaskStatusName($status)
{
    global $link;
    $name = '';
    $color = '';
    $query = mysqli_query($link,"select * from task_status_names where id=".$status);
    if ($res = mysqli_fetch_array($query))
    {
        $name = $res['name'];
        $color = $res['color'];
    }
    return array ($name, $color);
}

function GetHrefActive($href, $name, $li=true)
{
    global $act;
    $hrefactive = '';
    if ($href == $act) {
        $hrefactive = ' style="color:blue" class="active" ';
    }
    $liopen = '<li>';
    $liclose = '</li>';
    if ($li == false)
    {
        $liopen = '';
        $liclose = '';
    }
    echo $liopen.'<a class="menuleft" href="?act='.$href.'"'.$hrefactive.'>'.$name.'</a>'.$liclose;
}

function GetAccordeonNum($act)
{
    $accordnum = 0;
    switch($act)
    {
        case "global": $accordnum = 0;break;
        case "companies": $accordnum = 0;break;
        case "projects": $accordnum = 0;break;
        case "locations": $accordnum = 0;break;
        case "projects_old": $accordnum = 0;break;
        case "project_types": $accordnum = 0;break;
        case "loco": $accordnum = 0;break;
        case "penalties": $accordnum = 3;break;
        case "filelib": $incl ="filelib/in.php";break;
        case "accounts": $incl ="accounts.php";$accordnum = 0;break;
        case "analytics": $incl ="analytics.php";$accordnum = 0;break;
        case "markers": $incl ="markers.php";$accordnum = 1;break;
        case "tasks": $incl ="tasks.php";$accordnum = 2;break;
        case "checkpoints": $incl ="checkpoints.php";$accordnum = 2;break;
        case "checkitems": $incl ="checkitems.php";$accordnum = 2;break;
        case "tasksdone": $incl ="tasksdone.php";$accordnum = 2;break;
        case "tasktypes": $incl ="tasktypes.php";$accordnum = 2;break;
        case "docs": $incl ="docs.php";$accordnum = 4;break;
        case "reports": $incl ="reports.php";$accordnum = 4;break;
        case "journal": $incl ="journal.php";$accordnum = 4;break;
        case "devices": $incl ="devices.php";$accordnum = 1;break;
        case "staff": $incl ="staff.php";$accordnum = 3;break;
        case "objects": $incl ="objects.php";$accordnum = 1;break;
        case "object": $incl ="object.php";$accordnum = 1;break;
        case "typeobject": $incl ="typeobject.php";$accordnum = 1;break;
        case "input_data": $incl ="input_data.php";$accordnum = 3;break;
        case "jobs": $incl ="jobs.php";$accordnum = 3;break;
        case "dashboard": $incl ="dashboard.php";$accordnum = 0;break;
    }
    return $accordnum;
}

function GetInclude($act, $cmdlevel)
{
    $incl = '';
    $accordnum = GetAccordeonNum($act);
    if ($cmdlevel==10) {//head admins
        switch($act) {
            case "asusg_dayplan": $incl ="asusg_dayplan.php";break;
            case "penalties": $incl ="penalties.php";break;
            case "loco": $incl ="loco.php";break;
            case "locations": $incl ="locations.php";break;
            case "algo": $incl ="algo.php";break;
            case "locations2": $incl = "locations2.php";break;
            case "global": $incl ="global.php";break;
            case "companies": $incl ="companies.php";break;
            case "accounts": $incl ="accounts.php";break;
            case "markers": $incl ="markers.php";break;
            case "tasks": $incl ="tasks.php";break;
            case "tasksdone": $incl ="tasksdone.php";break;
            case "analytics": $incl ="analytics.php";break;
            case "mp_using": $incl ="user_activity.php";break;
            case "checkpoints": $incl ="checkpoints.php";break;
            case "checkitems": $incl ="checkitems.php";break;
            case "tasktypes": $incl ="tasktypes.php";break;
            case "docs": $incl ="docs.php";break;
            case "reports": $incl ="reports.php";break;
            case "devices": $incl ="devices.php";break;
            case "projects": $incl ="projects.php";break;
            case "project_types": $incl ="project_types.php";break;
            case "projects_old": $incl ="projects_old.php";break;
            case "staff": $incl ="staff.php";break;
            case "objects": $incl ="objects.php";break;
            case "object": $incl ="object.php";break;
            case "typeobject": $incl ="typeobject.php";break;
            case "input_data": $incl ="input_data.php";break;
            case "jobs": $incl ="jobs.php";break;
            case "dashboard": $incl ="dashboard.php";break;
            case "journal": $incl ="journal.php";break;
	        case "filelib": $incl ="filelib/in.php";break;
	        case "addproject": $incl ="addproject.php";break;
	        case "oprt_management": $incl ="oprt_management.php";break;
            case "_peekdatasafe" : $incl = "_peekdatasafe.php";break;
            case "_log" : $incl = "_log.php"; break;
            //--Левое меню
            //Список устройств
            case "tmc/new" : case "tmc/list_materials" : case "tmc/detail/added" : $incl = "tmc/new.php"; break;
            case "tmc/repair" : case "tmc/repair_list" : $incl = "tmc/repair.php"; break;
            case "tmc/write" : case "tmc/write_list" : $incl = "tmc/write-off.php"; break;
            case "tmc/edit" : $incl = "tmc/edit.php"; break;
            //Передача устройств
            case "tmc/issued_tmcs" : $incl = "tmc/issued_tmcs.php"; break;
            case "tmc/free_tmcs" : $incl = "tmc/free_tmcs.php"; break;
            case "tmc/give" : case "tmc/list_materials_give" : $incl = "tmc/give.php"; break;
            case "tmc/take" : $incl = "tmc/take.php"; break;
            //Места хранения
            case "tmc/storage" : $incl = "tmc/new_storage.php"; break;
            case "tmc/find_cell" : $incl = "tmc/find_cell.php"; break;
            case "views/metrics" : $incl = "views/metrics.php"; break;
            default:
        }
    }
    else if ($cmdlevel==1)	//company admin
    {
        switch($act)
        {
            case "penalties": $incl ="penalties.php";break;
            case "loco": $incl ="loco.php";break;
            case "locations": $incl ="locations.php";break;
            case "companies": $incl ="companies.php";break;
            case "accounts": $incl ="accounts.php";break;
            case "markers": $incl ="markers.php";break;
            case "tasks": $incl ="tasks.php";break;
            case "tasktypes": $incl ="tasktypes.php";break;
            case "docs": $incl ="docs.php";break;
            case "reports": $incl ="reports.php";break;
            case "staff": $incl ="staff.php";break;
            case "projects": $incl ="projects.php";break;
            case "objects": $incl ="objects.php";break;
            case "input_data": $incl ="input_data.php";break;
            case "jobs": $incl ="jobs.php";break;
            case "dashboard": $incl ="dashboard.php";break;
            case "journal": $incl ="journal.php";break;
            default:
        }
    }
    else if ($cmdlevel==2)	//company ops
    {
        switch($act)
        {
            case "markers": $incl ="markers.php";break;
            case "tasks": $incl ="tasks.php";break;
            case "tasktypes": $incl ="tasktypes.php";break;
            case "docs": $incl ="docs.php";break;
            case "reports": $incl ="reports.php";break;
            case "staff": $incl ="staff.php";break;
            case "projects": $incl ="projects.php";break;
            case "input_data": $incl ="input_data.php";break;
            case "dashboard": $incl ="dashboard.php";break;
            case "journal": $incl ="journal.php";break;
            default:
        }
    }
    return array($incl,$accordnum);
}

function getConfirmTypeName($id)
{
    global $link;
    $query = mysqli_query($link,"select * from confirmtypes where id=".$id);
    if ($query && $res = mysqli_fetch_array($query))
    {
        $name = $res['name'];
    }
    return $name;
}

function GrabConfirmTypes($company = 0)
{
    global $link;
    $str = "select * from confirmtypes where company=0";
    $types = array();
    if ($company > 0)
        $str .= " OR company=".$company;

    //echo "GrabConfirmTypes $company $str";
    $query = mysqli_query($link,$str);
    while ($query && $res = mysqli_fetch_array($query))
    {
        array_push($types, $res);
    }
    //print_r($types);
    return $types;
}

function getConfirmTypebyTask($tid)
{
    global $link;
    $query = mysqli_query($link,"select type from tasks where id=".$tid);
    if ($res = mysqli_fetch_array($query)) {
        $tasktype = $res['type'];
//        echo "tid $tid tasktype $tasktype ";
    }
    $query = mysqli_query($link,"select confirmtype from tasktypes where id=".$tasktype);
    if ($res = mysqli_fetch_array($query))
    {
        $confirmtype = intval($res['confirmtype']);
//        echo " confirmtype $confirmtype ";
    }
    return $confirmtype;
}

function GetOnlineAccountList($byteAnswer = false)
{
    global $link;
    //$date2 = date(strtotime("-3 minutes"));
//    echo 'GetOnlineAccountList1';
    $date = 'last_seen_mobile';
    ///$query = mysqli_query("select * from accounts where DATE(".$date.") < (NOW() + INTERVAL 1 DAY)");
    $query = mysqli_query($link,"select * from accounts where ".$date." > (NOW() - INTERVAL 3 MINUTE)");
    $accs = array();
    while ($res = mysqli_fetch_array($query))
    {
        array_push($accs, $res);
    }
    if (!$byteAnswer)
    {
        ;
//        foreach ($accs as $acc)
//        {
//            echo 'online acc '.$acc['name'].'<br>';
//        }
    }
    else
    {
        $buf = "";//pack("C", 10);
        foreach ($accs as $acc) {
            $buf .= pack("l", $acc['id']);    //заголовок - номер пакета 1б и длина 2б. v-ushort, c- byte, C- ubyte, s - short, L - int, l - uint
        }
        $c = ConstructVariablePacket(10, $buf);
        echo base64_encode($c);
    }
}

function Online($acc_id)
{
    $acc = GetAccount($acc_id);
    return OnlineAccountCheck($acc['last_seen_mobile'], 1);
}

function TimeString($timeobj)
{
    if ($timeobj != null)
        return $timeobj->format('d.m.Y H:i');

    //return date('d.m.Y H:i', $timeobj);
}

function OnlineAccountCheck($last_seen)
{
    //var_dump($last_seen);
    global $onlineMobileTimeoutSeconds;
    $last_seen = date($last_seen);
    $time = (time()-strtotime($last_seen));
    //$date1 = date('d.m.Y H:i', strtotime($last_seen_mobile));
    if ($time <= $onlineMobileTimeoutSeconds)
        return true;
    return false;
}

function GrabTasksByType($type)
{
    global $link;
    $str = "select * from tasks where type=$type";
    $query = mysqli_query($link, $str);
    $tasks = array();
    while ($res = mysqli_fetch_array($query))
    {
        array_push($tasks, $res);
    }
    return $tasks;
}

function DeleteTasksByType($task_type, $full=true)
{
    global $link;
    $tasks = GrabTasksByType($task_type);
    foreach ($tasks as $task)
    {
        DeleteTask($task['id']);
    }
}

function ClearTaskTypeFromJobs($task_type)
{
    global $link;
    $query1 = mysqli_query($link, "select * from jobtypes where $task_type in (tasktypes)");
    $jobs = array();
    while ($res1 = mysqli_fetch_array($query1))
    {
        array_push($jobs, $res1);
    }
    //print_r($jobs);
    foreach ($jobs as $job)
    {
        $tasktypes = explode(",", $job['tasktypes']);
        foreach (array_keys($tasktypes, "$task_type") as $key) {
            unset($tasktypes[$key]);
        }
        $tasktypes = implode(",", $tasktypes);
        mysqli_query($link, "update jobtypes set tasktypes = '$tasktypes'");
    }
}

function DeletePic($path)
{
    unlink ( $path );
}

function DeleteTask($task_id, $full=true)
{
    //echo "DeleteTask!!!";
    CheckPoint::DeleteByTask($task_id);
    global $link;
    if ($full)
    {
        $subtasks = GrabSubTasks($task_id);
        foreach ($subtasks as $sub)
        {
            DeleteTask($sub['id'], false);
        }
    }
    $accid = GetAccountFromTask($task_id);
    Account::ClearTasksFromAccount($accid);
    mysqli_query($link, "delete from tasks where id =".$task_id);
}

function GetImagePathFromTask($task)
{
    $taskid = $task->id;
    $companyID = getCompanyByTask($taskid)[0];
    $project_id = $task->input_id;
    $imgpath = "data/$companyID/$project_id/$taskid/";
    return $imgpath;
}

function GetVideoPathFromTasktype($taskid)
{
//    $rootPath = $_SERVER['DOCUMENT_ROOT'];
//    $videoPath = $rootPath."/guides/$taskid/";
    $videoPath = "guides/$taskid/";
    return $videoPath;
}

//in minutes
function TimeSpent($timeStart, $timeEnd)
{
    $accepted  = strtotime($timeStart);
    $finished = strtotime($timeEnd);
    return round(($finished - $accepted)/60.0, 0, PHP_ROUND_HALF_UP);
    //return round (($finished - $accepted)/60.0, 2);
}

function TimeSpentForTaskFromArray($taskarr)
{
    $accepted_time = $taskarr['accepted_time'];
    $finished_time = $taskarr['finished_time'];
    $accepted  = strtotime($accepted_time);
    $finished = strtotime($finished_time);
    //return round (($finished - $accepted)/60.0, 2);
    return $finished - $accepted;
    //return round(($finished - $accepted)/60.0, 0, PHP_ROUND_HALF_UP);
}

function GetAssigneeNamesfromGlobal($taskid)
{
    global $link;
    $str = "select id from tasks where parent_id = $taskid";
    $query1 = mysqli_query($link, $str);
    $accids = array();
    while ($res1 = mysqli_fetch_row($query1)) {
//        array_push($accids, $res1['assignees_arr']);
        $accid = FindTaskOwner($res1[0]);
//        var_dump($accid);
//        echo "tid ".$res1[0];
        array_push($accids, $accid);
    }

    $accarr = array();
    $accnames = array();

    foreach ($accids as $accid)
    {
        if (!in_array($accid, $accarr)) {
            array_push($accarr, $accid);
            $accname = GetAccount($accid)['name'];
            array_push($accnames, $accname);
        }
    }
    $assignee_names_parent = implode(",", $accnames);
    return $assignee_names_parent;
}

function EchoScriptName($name)
{
    echo "<script>
    var page = '$name';";
    echo "</script>";
}


function GetProject($project_id)
{
    global $link;
    $str = "select * from projects_locotech where id = $project_id";
    
    $query1 = mysqli_query($link, $str);
    
    if ($res1 = mysqli_fetch_array($query1)) {
        return $res1;
    }
    return 0;
}

function GetLocoSerial($project_id)
{
    global $link;
    $str = "select loco_number from projects_locotech where id = $project_id";
    $query1 = mysqli_query($link, $str);
    if ($res1 = mysqli_fetch_row($query1)) {
        return $res1[0];
    }
    return 0;
}

function CleanTasks($project_id)
{
    global $link;
    $str = "select id from tasks where input_id = $project_id";
    $query1 = mysqli_query($link, $str);
    while ($res1 = mysqli_fetch_row($query1)) {
        $taskid = $res1[0];
        DeleteTask($taskid);
    }
}

function EchoTask2(Task $task, $activeid, $parent = false)
{
    global $entityManager;
    $tasktype_id = $task->type;
    /**
     * @var $type Tasktype
     */
    $type = Tasktype::Find($tasktype_id);

    $taskname = $type->name;
    $letter = $type->letter;
    $lettersign = "";
    if ($letter)
        $lettersign = "[Секция $letter]";
    $project_id = intval($task->project->id);
    $project = $task->project;
    //$action_id = $project->getAction();
//    $action = $project->getProjectType();
    $action = $project->projecttype;
//    if ($action != null)

//    if (!isset($action)) {
//        echo "action $action_id null";
//        return;
//    }
    try {
        $action_id = $action->id;
        $action_name = $action->name;
    }
    catch (Exception $e)
    {
//        echo "exception ".$e->getMessage();
//            \Doctrine\Common\Util\Debug::dump($action);
    }
    $created_time = TimeString($task->created);
    $taskid = $task->id;
    $assigned = TimeString($task->assigned);
    $zone = $task->zone_id;
    $zonename = GetZoneName($zone);
    $zone_req= $type->zone_required_id;
    $zone_req_name = GetZoneName($zone_req);
    $status = $task->status;
    $statusname = getTaskStatusName($status);
    $desc = $task->text;//$type->description;
    $loco = GetLocoSerial($project_id);
    $section = Section::Find($loco);
//    if ($section)
//        $loco = $section->getSectionNumber();
    $class = 'content__menu__task';
    $assignee_id = $task->assignees_arr;

    if ($activeid == $taskid)
        $class .= ' content__menu__task_active';
    else
        $class .= ' list';

    //PARENT LIST TO LEFT
    if ($parent) {
//        \Doctrine\Common\Util\Debug::dump(isset($task->getAccount());
        if ($task->getAccount() != null && 0 < $task->assignees_arr) {
            $assignee_names_parent = $task->getAccount()->name;//GetAssigneeNamesfromGlobal($taskid);
        }

        if ($status != '1')
            $statusname[0] .= ': '.$assignee_names_parent."<br> Выдана: $assigned ";

        //echo "111 $assignee_names_parent $taskid $class $taskname $desc $project_id  $action_id $action_name $created_time ".$statusname[0];
        echo "<div onclick='SelectTask($taskid)' class='$class'>
                <h3 class='content__menu__task-title'>
                    $taskid. $taskname <br>
                    $lettersign<br>
                    Описание: $desc
                </h3>
                <p class='content__menu__task-text'>
                    Проект: $project_id<br>
                    Тип проекта: $action_id. $action_name<br>
                    Локомотив №: $loco <br>
                    Создана: $created_time  <br>  <br>
                    $statusname[0]
                </p>                
            </div>";
    }
    else
    {
        $confirmtype = $type->confirmtype;
        $confirmname = getConfirmTypeName($confirmtype);
        $priority = $task->priority.'.';
        $assignee_names = GetAccount($assignee_id)['name'];
        if ($status =='2' || $status =='3' || $status =='5')
            $statusname[0] .= ': '.$assignee_names;
        $statustitle = $statusname[0];
        if ($status =='3')
            $statusname[0] = "<span style='color: green'>$statusname[0]</span>";

        $statusclass = 'content__main__item';

        switch ($status)
        {
            case '2': $statusclass .= ' content__main__item_wait'; break;
            case '3': $statusclass .= ' content__main__item_wait'; break;
            case '4': $statusclass .= ' content__main__item_wait'; break;
            case '5': $statusclass .= ' content__main__item_ready';
                $accepted_time = TimeString($task->accepted_time);
                $finished_time = TimeString($task->finished_time);
                $timetodo = intval($type->time_to_complete_minutes);
                $result = TimeSpent($accepted_time, $finished_time);
                //echo "acc $accepted_time fin $finished_time <br>";
                if (!$parent) {
                    if ($result >= 0)
                        $result = " за $result из $timetodo минут";
                    $statusname[0] .= ': ' . $accepted_time.$result;
                }
            break;
        }

        $zoneOk = (intval($zone_req)== intval($zone));
        if ($zoneOk)
        {
            $zoneText = "соответствие";
            $zonecolor = "green";
        }
        else {
            $zoneText = "неверно";
            $zonecolor = "red";
        }
        if ($zone)
            $zonestring =  "<span style='color: $zonecolor'>[$zoneText]</span>";
        else
            $zonestring =  "";
        echo "
        <div class='$statusclass' title='$statustitle'>
            <h3 class='content__main__item__title'>
                $priority $taskname
            </h3>
            <p class='content__main__item__text'>
               Тип задачи: $tasktype_id<br>
               Описание: $desc <br>
               Тип подтверждения: $confirmname<br>
               $taskid. Создана $created_time<br>
               Выдана: $assigned<br>
               Зона выполнения: $zone ($zonename) $zonestring<br>
               Зона выполнения требуемая: $zone_req ($zone_req_name)<br>
               $statusname[0]<br><br>
                Вы можете <span class='content__main__item__del' onclick='DelTask($taskid)'>удалить</span>
                или <span class='content__main__item__recall' onclick='Revoke($assignee_id)'>отозвать</span> эту задачу,
                если что-то пошло не так.
            </p>
        </div>
        ";

        $cps = CheckPoint::FindAllByTask($taskid);
        if (sizeof($cps) > 0)
        {

        //echo "<p>";
            echo "<div style='margin-left: 50px'>";
            echo "<h4>Контрольная карта:</h4>";
            foreach ($cps as $cp) {
                if ($cp->parentCheckpointId == 0)
                {
                    echo "<b>$cp->id. [$taskname]<br> $cp->name:</b><br>";
                }
                
                if ($cp->value != null)
                    echo $cp->value . '<br>';
//                else {
                    $children = $cp->childrenCheckpoints;
                    if (0 < count($children))
                    {
                        echo '<ul>';
                        foreach ($children as $child) {
                            if ('1' == $child->state)
                            {
                                if ('' == $child->value)
                                    echo "<li>$child->name</li>";
                                else
                                    echo "<li>$child->name: $child->value</li>";
                            }
                        // У чайлдов замечаний нет. ПИА.
                        /*$textnotes = $entityManager->getRepository('Tasknote')->findBy(array('checkpoint_id' => $child->id));
                        foreach ($textnotes as $tn)
                        {
                            echo "Замечание: $tn->text<br>";
                        }/**/
                        }
                        echo '</ul>';
                    }
//                }
                    
                if ($cp->parentCheckpointId == 0)
                {
                    $textnotes = $entityManager->getRepository('Tasknote')->findBy(array('checkpoint_id' => $cp->id));
                    foreach ($textnotes as $tn)
                    {
                        echo "<pre>  Замечание: $tn->text</pre>";
                    }
                }

            }
            echo "</div><br><br>";
        }
        //echo "</p>";
        //LOAD MEDIA DATA

        $imgpath = GetImagePathFromTask($task);
        $files1 =  scandir($imgpath);
        //print_r($files1);

        if (sizeof($files1) > 2)
        {
            echo '<div class="content__main__images" style="margin-left: 44px; margin-right:44px">';
            $x = '';
            foreach ($files1 as $file )
            {
                $prevx = $x;
                $x = pathinfo($file)['extension'];
                if ($prevx != '' && $prevx != $x)
                    echo "<br>";

                if($file === '.' || $file === '..') {continue;}
                if ($x == 'jpg') {
                    echo "<div class='content__main__imgwrap'>";
                    echo "<img title='$file' src='$imgpath$file' width =112 height='84' class='content__main__img' onclick=\"openpic('" . $imgpath.$file . "')\">";
                   echo '<img src="ProSysNew/delete.svg" alt="удалить" class="content__main__imgdel" onclick=delpic("'. $imgpath . $file .'")>';
                     echo '</div>';
                }
                if ($x == 'mp3') {
                    echo "<div class='content__main__imgwrap'>
                            <img class='content__main__img' title='$file'  onclick=\"openaudio('" . $imgpath . $file . "')\"  src='images/audio.svg'>
                    </div>";
                    //  echo "<a href='$imgpath$file'>$file</a>";
                }
            }
            echo '</div>';
        }
        $notes = FindTaskNotes($taskid);
        if (sizeof($notes) > 0) {
            echo "<div style='float:none; background-color: rgba(0,170,255,0.03); padding: 5px; border: solid; margin-right:44px; margin-left:44px;  border-width: .5px; border-color: #9cb2c4; border-radius: 10px; border-top-left-radius: 0px;'><p><b>Текстовые заметки: </b></p>";
            foreach ($notes as $note) {
                if (!$note['checkpoint_id']) {
                    $notedate = $note['date'];
                    $noteid = $note['id'];
                    $notetext = $note['text'];
                    echo "<p><b>$noteid.</b> [$taskname] $notetext</p>";
                }
            }
            echo '</div><br><br>';
        }
    }
    //locotube
    if ($task->parent_id) {
        echo '<div class="content__main__images" style="margin-left: 44px; margin-right:44px">';
        showVideoLinks($task);
//        getTaskVideos($task);
        echo '</div>';
    }
    //video files
        echo '<div class="content__main__images" style="margin-left: 44px; margin-right:44px">';

            $ocsVideo = OCSgetvideo($taskid);
            $splitted = explode(",",$ocsVideo);
            $domain = "http://ocs.prmsys.net/video/";

            foreach ($splitted as $spl) {
                if ($spl == "")
                    continue;
                $link = "$domain$spl";
                echo "<div class='content__main__imgwrap' onclick=\"openvideo('$link')\">
                    <video height='144' class='content__main__img' preload='metadata' title='$link'>
                        <source src='$link'>
                    </video>
                </div>";
            }
        echo '</div>';
    echo '<div>';
    if ($status != '1')
        echo " <input style='margin-right: 20px' type='button' onclick='ReopenTask($taskid)' value='Открыть заново'>";

    echo '</div>';
}

function showVideoLinks($task)
{
    $urls = \app\models\entity\Locotube::getLinks($task, 310);
    foreach ($urls as $url): ?>
        <a href="<?= $url ?>" target="_blank">
            <img style="width: 32px; height: 32px; margin-bottom: 14px" src="images/mp4.png" alt="mp4">
        </a>
    <? endforeach;
}

function getTaskVideos(Task $task)
{
    if ('DateTime' != get_class($task->accepted_time)) return;

    $userId = $task->getAccount()->getId();

    $sp = DIRECTORY_SEPARATOR;

    $path = $sp . 'uploads' . $sp . 'locotube' . $sp . $userId . $sp;
    $fullPath = __DIR__ . $path;
    if (is_dir($fullPath)) {
        $files = scandir($fullPath);

        $start = $task->accepted_time;
        $finish = $task->finished_time;
        foreach ($files as $file) {
            if ($file[0] == '.') continue;

            $videoDate = parseDate($file);
            if ($start <= $videoDate && $videoDate <= $finish) { ?>
                <a href="/player.php?file=<?= $path . $file ?>" target="_blank">
                    <img style="width: 32px; height: 32px; margin-bottom: 14px" src="images/mp4.png" alt="mp4">
                </a>
            <?php
            }
        }
    }
}

function parseDate(string $str)
{
    $date = new DateTime();
//    $date->setTimezone(new DateTimeZone('+0010'));
    $y = substr($str, 0, 4);
    $m = substr($str, 5, 2);
    $d = substr($str, 7, 2);
    $date->setDate($y, $m, $d);
    $h = substr($str, 10, 2);
    $i = substr($str, 12, 2);
    $s = substr($str, 14, 2);
    $date->setTime($h, $i, $s);

    return $date;
}

function FindTaskNotes($taskID)
{
    global  $link;
    $query = mysqli_query($link,"select * from task_notes where task_id=".$taskID);
    $notes = array();
    while ($res1 = mysqli_fetch_array($query))
    {
        array_push($notes, $res1);
    }
    return $notes;
}

function ActionsForm($action_data, $c_action)
{
    echo "<option selected value = '0' ><Выберите тип проекта></option >";
    foreach ($action_data as $val) {
        if ($val->id == $c_action)
            $sel = 'selected';
        else
            $sel = '';
        echo "<option $sel value = '".$val->id."' > ".$val->name."</option >";
    }
}

function AddJob($acc_id, $new_jobtype_id, $job_ids)
{
    global  $link;
    $job_ids .= ','.$new_jobtype_id;
    mysqli_query($link, "update accounts set jobtypes='".$job_ids."' where id=".$acc_id);
    echo "<span style='color: darkolivegreen'>Должность добавлена!</span><br><br>";
}


function JobTaskTypesIDs($job_id)
{
    $tts = GrabJobTaskTypes($job_id);
    $arr = array();
    if (sizeof($tts) > 0) {
        foreach ($tts as $tt) {
            array_push($arr, $tt->id);
        }
    }
    return $arr;
}

function GrabJobTaskTypes($job_id)
{
    /**
     * @var Jobtype$jobtype
     */
    $tasktypes = array();
    $jobtype = Jobtype::Find($job_id);
    if ($jobtype != null)
        $tasktypes = $jobtype->getTaskTypes();

    return $tasktypes;
}

//function GrabJobTaskTypes($job_id)
//{
//    global $link;
//    $subtaskarr = array();
//    $query = mysqli_query($link,"select tasktypes from jobtypes where id=".$job_id);
//    if ($res = mysqli_fetch_row($query)) {
//        $tasktype_data = $res[0];
//        $subtaskarr = explode(",", $tasktype_data);
//    }
//    return array_filter($subtaskarr);
//}

function ShowJobTasks($job_id)
{
    $subtaskarr = GrabJobTaskTypes($job_id);
    foreach ($subtaskarr as $taskid) {
        $taskarr = GrabTasktype($taskid);
        $name = $taskarr['name'];
        if ($name != '')
            echo '<span style=\'color:blue\'>'.$taskarr['name'].'</span> <b>|</b> ';
    }
}

function FillArrayString($elem_name, $make_array = false)
{
    //echo sizeof($_REQUEST)." elname $elem_name<br>";
    //print_r($_REQUEST);
    $subtask_arr = array();
    foreach (array_keys($_REQUEST) as $var) {
        //echo "var $var ${$var} <br>";
        $sub = substr($var, 0, -1);
        $sub2 = substr($var, 0, -2);
        $sub3 = substr($var, 0, -3);
        //echo "sub $sub<br>";
        if ($sub === $elem_name || $sub2 === $elem_name || $sub3 === $elem_name)
        {
            if ($_REQUEST[$var] != '')
                array_push($subtask_arr, $_REQUEST[$var]);
        }
    }
    
    $subtask_string = implode(",", $subtask_arr);
    if ($make_array) {
        $subtask_string = $subtask_arr;
    }
    //print_r($subtask_arr);
    return $subtask_string;
}


function ShowTasksSelect($arr, $c_action=0, $id="", $keyword, $alg=false)
{
    if ($id !="") {
        $id = "id='$id'";
    }
    $max = sizeof($arr);
    echo "<select onchange='AddSelect(this.value, $max)' $id class='form-input content__main__form__goal'  name='$keyword"."1' >";
    echo '<option value=""></option>';
    $count=1;
    foreach ($arr as $res1) {
        if ($c_action ==0 || $res1->action == $c_action)
        {
            $tasktype_id = $res1->id;
            $taskname = $res1->name;
            if (!isset($taskname)) {
                $type = $res1->type;
                $name = GetTaskNameAndDesc($type)[0];
                $taskname = "$tasktype_id. $name [$type]";
            }
            echo "<option value='$tasktype_id'>$count. $taskname</option>";
            $count++;
        }
    }
    echo '</select><br>';
    if ($alg) {
        echo "<select style='margin-left:20px ' class='form-input content__main__form__goal' id='alg' name='alg' >";
        echo '<option value="">Собрать результат выполнения задачи</option>';
        echo '<option value="">Составить промежуточную таблицу</option>';
        echo '<option value="">Алгоритм3</option>';
        echo '<option value="">Алгоритм4</option>';
        echo '</select><br>';
    }
}

function GetJobtypes($companyID)
{
    global $link;
    $query1 = mysqli_query($link, "select * from jobtypes where company=$companyID");
    $jobtypes = array();
    while ($res1 = mysqli_fetch_array($query1))
    {
        array_push($jobtypes, $res1);
    }
    return $jobtypes;
}

function GetAccountFromTask($task_id)
{
    global $link;

    $str = "select assignees_arr from tasks where id = ".$task_id;
    $query1 = mysqli_query($link, $str);
    if ($res1 = mysqli_fetch_row($query1)) {

        return $res1[0];
    }
    return null;
}

function GetVagrantTagID($acc_id)
{
    global $link;

    $str = "select tagid from vagrant_log where acc_id = $acc_id ORDER BY id DESC limit 1";

    $query1 = mysqli_query($link, $str);
    if ($res1 = mysqli_fetch_row($query1)) {

        return $res1[0];
    }
    return null;
}

function GetAccount($acc_id)
{
    global $link;

    $str = "select * from accounts where id = ".$acc_id;
    $query1 = mysqli_query($link, $str);
    if ($res1 = mysqli_fetch_array($query1)) {

        return $res1;
    }
    return null;
}

function GetAccountJobs($acc_id)
{
    global $link;
//    echo 'GetAccountJobs '.$acc_id;
    //get free accs (without active tasks)
    $str = "select * from accounts where id = ".$acc_id;
    $query1 = mysqli_query($link, $str);
    if ($res1 = mysqli_fetch_array($query1)) {
//        echo 'jobs '.$res1['jobtypes'];
        $jobtypes = explode(",",$res1['jobtypes']);
        return $jobtypes;
    }
}

function GetCMDName($cmdlevel)
{
    global $link;
    $str = "select name from accounttypes where type = ".$cmdlevel;
    $query1 = mysqli_query($link, $str);
    if ($res1 = mysqli_fetch_array($query1))
        return $res1['name'];
}


function GetTasksFromProjectString($projectid)
{
    global $link;
    $str = "select tasks from projects_locotech where id = $projectid";

    $query1 = mysqli_query($link, $str);
    $ret = array();
    if ($res1 = mysqli_fetch_row($query1))
    {

        $ret = $res1[0];
    }
 
    return $ret;
}

function GetTasksForProject($projectid, $status=0, $inactiveproject=0, $subs = 0)
{
    global $link;
            
    $taskstring = GetTasksFromProjectString($projectid);
    if ($inactiveproject != 0)
    {
        $str = "select COUNT(id) from tasks where id in ($taskstring) and (status=2 or status=3)";
        $query1 = mysqli_query($link, $str);
        if ($res1 = mysqli_fetch_row($query1))
        {
            $count = intval($res1[0]);
            if ($count > 0) {
                echo "Found started tasks!";
                return;
            }
        }
    }
    if ($subs > 0) {

        //echo "subss!";
        $tasksarr = explode(",", $taskstring);
        foreach ($tasksarr as $task_id)
        {
            $parent = GrabTask($task_id);
            if ($parent['status'] == $status) {
                return GrabSubTasks($task_id);
            }
        }
    }
    $statusstr = '';
    if ($status != 0)
        $statusstr .= " and status=$status";

//    $str = "select * from tasks where input_id = ".$projectid." and parent_id=0";
    $str = "select * from tasks where id in ($taskstring)$statusstr";
    $query1 = mysqli_query($link, $str);
    $ret = array();
    
    while ($res1 = mysqli_fetch_array($query1))
        array_push($ret, $res1);
    return $ret;
}

function GetJobNames($jobtypes)
{
    global $link;
    $jobnames = array();
    foreach ($jobtypes as $jobid)
    {
//        echo ' jobid '.$jobid;
        $str = "select name from jobtypes where id = ".$jobid;
        $query1 = mysqli_query($link, $str);
        if ($res1 = mysqli_fetch_array($query1)) {
            $jobname = $res1['name'];
//            echo ' jobname '.$jobname;
            //$jobnames[$jobid] = $jobname;
            array_push($jobnames, $jobname);
        }
    }
    return $jobnames;
}

function TaskReopen($tid)
{
    global $link;
    mysqli_query($link, "update tasks set status=1, assignees_arr=0 where id=".$tid);
}

function FindUrgentAccounts()
{
    global $link;
    $str ="select DISTINCT a.id, p.id from accounts a join tasks t on t.assignees_arr= a.id  join projects_locotech p on p.id = t.input_id where p.urgent=1 and p.status<5";
    $query = mysqli_query($link, $str);
    $retarr = array();
    while ($res = mysqli_fetch_row($query))
    {
        $retarr[] = $res[0];
    }
    return $retarr;
}

function CheckPreferredAssignee(&$opentasks, $echo)
{
    global $link;
    $pids = array();
    $prefs = array();
    foreach ($opentasks as &$opentask)
    {
        $tid = $opentask['id'];
        $pref = intval($opentask['preferred_assignee']);

        if ($pref > 0) {
            if ($echo)
                echo ("CheckPreferredAssignee pref>0: $tid");
            $opentask['status'] = 2;
            $str = "update tasks set status = 2, assigned=NOW(), assignees_arr=$pref where id=$tid";
            mysqli_query($link, $str);

            $pid = intval($opentask['parent_id']);
            if ($pid > 0 && !in_array($pid, $pids)) {
                $pids[] = $pid;
                $prefs[$pid] = $pref;
            }
        }
    }
    if ($echo) {
        $plen = sizeof($pids);
        echo("pids len: $plen");
    }
    foreach ($pids as $pid)
    {
        $str = "update tasks set status = 2, assigned=NOW(), assignees_arr=".$prefs[$pid]." where id=$pid";
        mysqli_query($link, $str);
    }
}

function TasksAssignCore($freeaccounts, $task_id, $execute, $project_id, $echo = false)
{
    global $link, $companyID;
    
    $assigned_tasks = array();
    $accsused = array();
    $project = null;
    if ($task_id =='' || !isset($task_id))
    {
        if ($project_id == 0)
            $opentasks = GrabOpenTasks('subtasks');   //array of mysql res, tasks status=1
        else {
            $project = Project::Find($project_id);
            $opentasks = GetTasksForProject($project_id, 1, 0, 1);
        }
    }
    else
        $opentasks = GrabTasksFromGlobal($task_id);
//select * from accounts a left outer join tasks t on t.assignees_arr= a.id  left outer  join projects_locotech p on p.id = t.input_id where p.urgent=1 and a.id=1

    CheckPreferredAssignee($opentasks, $echo);

    if ($echo)
    {
        echo "<br>opentasks:<br>";
        var_dump($opentasks);

        echo "<br>freeaccounts:<br>";
        var_dump($freeaccounts);
    }
    $assigned_accs = array();
//    if ($echo) {
//        echo "<br>freeaccounts";
//        var_dump($freeaccounts);
//    }
    foreach ($freeaccounts as $acc_id=>$jobtypesIds)
    {
        $parent_id = 0;
        $assigned_accs[$acc_id]  = array();
        if (!in_array($acc_id, $accsused))
        {
            $tasktypesJob = array();
            foreach ($jobtypesIds as $job_type) {
                $tasktypesJob = array_merge($tasktypesJob, JobTaskTypesIDs($job_type));
            }
            foreach ($opentasks as $opentask)
            {
                $taskid = $opentask['id'];
                if (intval($opentask['status']) > 1)
                    continue;

                $exists = array_key_exists($taskid, $assigned_tasks);
                if ($echo)
                    echo ' key exists '.$taskid.' '.($exists == true).'<br>';
                if (!$exists) {
                    // echo '!exists';
                    if (in_array($opentask['type'], $tasktypesJob)) {
                        if ($echo)
                            echo ' job available task type '.$opentask['type'].' ';
                        $pid = intval($opentask['parent_id']);
                        if ($pid != $parent_id && in_array($acc_id, $accsused)) {//parent change = stop for this acc
                            if ($echo)
                                echo "cont1";
                            continue;
                        }
                        else
                            $parent_id = $pid;
                        $parent = GrabTask($parent_id);
                        $parenttype = $parent['type'];

                        $tgrab = GrabTasktype($parenttype);
                        $tsize = sizeof($tgrab);
                        if ($tsize == 0)
                            DeleteTasksByType($parenttype);

                        //фикс блуждающих подзадач без парента и тасктипа парента
                        if (($parent_id > 0 && GrabTask($parent_id) == null) || $tsize == 0)
                        {
                            if ($echo)
                                echo "skip2 id $parent_id<br>";
                            continue;
                        }
                        Assign($accsused, $assigned_tasks, $assigned_accs, $acc_id, $taskid, $execute);
                        if ($echo) {
                            echo "assigned_tasks:<br>";
                            var_dump($assigned_tasks);
                            echo "assigned_accs: <br>";
                            var_dump($assigned_accs);
                        }
                    }
                }
            }
            if ($execute)
            {
                $parent_updated = false;
                foreach ($assigned_accs as $acc)
                {
                    if (sizeof($assigned_accs[$acc_id]) == 0)
                        continue;
                    $tasks = implode(',', $acc);    //taskarr
                    foreach ($acc as $tsk) {
                        if (in_array($tsk, $assigned_accs[$acc_id])) {

                            if ($echo) {
                                echo '<br>updating task ' . $tsk . ' setting ass ' . $acc_id;
                            }
//                            var_dump($acc_id);
                            OCStaskstatus($tsk, 2, $acc_id);
                            $str = "update tasks set status = 2, assigned=NOW(), assignees_arr=$acc_id where id=$tsk";
                            require_once 'tmc/yiiInit_once.php';
                            \app\models\ElasticLog::command((int)$tsk, 'Назначение');
                            //echo '<br>'.$str;
                            mysqli_query($link, $str);   //создание подзадач
                        }
                    }
                    if ($parent_id != 0)
                        $tasks = $parent_id.','.$tasks;


//                    mysqli_query($link, "update accounts set active_task_ids = '$tasks' where id=".$acc_id);   //создание подзадач
                    if ($parent_id != 0 && !$parent_updated) {
                        $parent_updated = true;
                        OCStaskstatus($parent_id, 2, $acc_id);
                        mysqli_query($link, "update tasks set status = 2, assigned=NOW(), assignees_arr=$acc_id where id=" . $parent_id);
                        $proj = getProjectByTask($parent_id);
                        mysqli_query($link, "update projects_locotech set status = 2 where id=".$proj['id']);
                    }
                }
            }
        }
    }
    return $assigned_accs;
}

function CheckPush($accounts, $echo=false)
{
    foreach ($accounts as $account)
    {
//        if ($echo)
//            \Doctrine\Common\Util\Debug::dump($account);
        $lastpush = TimeString($account->last_push_message_sent);

        $time = (time()-strtotime($lastpush));
        if ($echo)
            echo $account->name." time $time";
        if ($time > 30)
            SendPush($account->id, "Check your SMoPP application!", "");
    }
}


function TasksAssign($task_id, $execute, $project_id = 0, $echo = false, $source = 0)
{
    //1 ищем онлайн акки без тасков
    //2 определяем основные должности акков
    //3 определяем замещяющие должности акков
    //4 определяем доступные задачи по должностям
    //5 берем активные (невыданные) задачи
    //6 выдаем подходящим основным аккам их подзадачи
    //7 выдаем подходящим замещающим аккам их подзадачи
    global $companyID;
    $freeaccountsPrimary = array();
    $freeaccountsSecondary = array();

    /**
     * @var $company Company
     */
    $company = Company::Find($companyID);
//    $last_assign = strtotime(TimeString($company->last_assign));
//    $time = (time()-$last_assign);
//    if ($echo)
//    {
//        var_dump($last_assign);
//        var_dump($time);
//    }
//
//    if ($time < 10)
//    {
//        if ($echo)
//            echo "часто";
//        return null;
//    }

    $companyID = $company->id;

    $company->last_assign = new \DateTime("now");
    $company->Save();

    if ($company == null)
        return array();

    $project = null;
    $urgent = 0;
    if ($project_id > 0)
    {
        $project = Project::Find($project_id);
        if ($project != null && intval($project->getStatus()) < 5 )
        {
            $urgent = $project->urgent;
        }
    }
    if ($urgent >0)
        $accs = $company->GetOnlineAccounts(true, true);
    else
        $accs = $company->GetIdleAccounts();

    if ($echo) {
        var_dump($urgent);
        if ($urgent >0)
            echo "urgent accs: ";
        else
            echo "idle accs: ";
        \Doctrine\Common\Util\Debug::dump($accs);
        echo "<br>";
    }

    $online_counter = sizeof($accs);
    foreach ($accs as $acc)
    {
        $jobtypesIdsPrimary = array();
        $jobtypesIdsSecondary = array();
        /**
         * @var $acc Account
         */
//        $last_seen_mobile = TimeString($acc->getLastSeenMobile());
//        $online_mobile = OnlineAccountCheck($last_seen_mobile);
//        if (!$online_mobile)
//            continue;
//        else
//            $online_counter++;
        $acc_id = $acc->getId();
        $jobtypes = $acc->getJobtypesExtended();
        foreach ($jobtypes[0] as $jobtype)
        {
            $jobtypesIdsPrimary[] = $jobtype->id;
        }
        foreach ($jobtypes[1] as $jobtype)
        {
            $jobtypesIdsSecondary[] = $jobtype->id;
        }
        $freeaccountsPrimary[$acc_id] = $jobtypesIdsPrimary;
        $freeaccountsSecondary[$acc_id] = $jobtypesIdsSecondary;
    }

    if ($online_counter == 0)
    {
        if ($echo)
            echo "<h3><span style='color:red'>Задачи не выданы в работу! Нет подходящих исполнителей онлайн</span></h3>";
        return array();
    }

    $assigned_accs1 = TasksAssignCore($freeaccountsPrimary, $task_id, $execute, $project_id, $echo);
    if ($echo) {
        echo "<br> assigned_accs1: ";
        var_dump($assigned_accs1);
    }

//    $assigned_accs2 = array();

    $accs1str = "";
    foreach ($assigned_accs1 as $id=>$taskids)
    {
        if (sizeof($taskids) > 0) {
            $acstr = implode(',',$taskids);
            $accs1str .= " $id: $acstr | ";
            SendPush($id, "You have a new task!", $acstr);
        }
//        var_dump($taskids);echo "<br>";
//        foreach ($taskids as $tid)
//        {
//            $task = Task::Find($tid);
//            if ($task != null)
//            {
//                $tt = $task->type;
//            }
//        }
//        if (sizeof($freeaccountsSecondary[$id]) > 0 && sizeof($taskids)>0) {
//            $task = Task::Find($taskids[0]);
//            if ($task != null) {
//                $proj_id = $task->input_id;
////            var_dump($proj_id);echo "<br>";
//                $freeaccs = array($id => $freeaccountsSecondary[$id]);
////            var_dump($freeaccs);echo "<br>";
//                $assigned_accs2 = TasksAssignCore($freeaccs, '', true, $proj_id);
////            var_dump($assigned_accs2);echo "<br>";
//            }
//        }
        if (sizeof($taskids) > 0)
            unset($freeaccountsSecondary[$id]);
    }
    $assigned_accs3 = TasksAssignCore($freeaccountsSecondary, $task_id, $execute, $project_id, $echo);
    foreach ($assigned_accs3 as $id=>$taskids)
    {
        if (sizeof($taskids) > 0) {
            $acstr = implode(',',$taskids);
            $accs1str .= " $id: $acstr | ";
            SendPush($id, "You have a new task!", $acstr);
        }
    }
    if ($accs1str != '')
        LogTaskAssign("Account: $source $accs1str");

//    if ($echo) {
//        echo "<br>  assigned_accs3: ";
//        var_dump($assigned_accs3);
//    }
    $retarr = array_merge($assigned_accs1, $assigned_accs3);
//    var_dump($retarr);

    return $retarr;
}

function LogTaskAssign($text)
{
    global $link;
    mysqli_query($link, "insert into task_assign_log (msg, created) values ('$text', NOW())");
}

function SendPush($accid, $text, $tskid)
{
    global $link;
    $acc = Account::Find($accid);
    if ($acc != null) {
        $android_token_id = $acc->android_token_id;
        if ($android_token_id) {
            //$f = file_get_contents("http://corp.prmsys.net/?act=staff");
            $text = "AccountId $accid taskids $tskid ".$text;
            $text = urlencode($text);
            require_once "fcm/SendNotification.php";
            $oldKey = ($acc->getCompany()->id == 1);
            Send($text, $android_token_id, $oldKey);
            $str = "update accounts set last_push_message_sent = NOW() where id=$accid";
            mysqli_query($link, $str);

//            $f = file_get_contents("http://corp.prmsys.net/fcm/SendNotification.php?text=$text&token=$android_token_id");
//            echo $f;
        }
//        else
//            echo "invalid token";
    }
}

function SetAccordNum($num)
{
    echo '<div style="display: none" id="accordnum">'.$num.'</div>';
}


function GetTaskNameAndDesc($type)
{
    global $link;
    $str = "select name, description from tasktypes where id = $type";
    $query1 = mysqli_query($link, $str);
    if ($res1 = mysqli_fetch_row($query1)) {
        return $res1;
    }
    return '';
}

function GetAccountTasksStatus()
{


}

function Assign(&$accsused, &$assigned_tasks, &$assigned_accs, $acc_id, $taskid, $execute=false)
{
    global $link;
    //echo '<br>foundacc ' . $acc_id .' task type '.$opentask['type'].' task id '.$opentask['id'].'<br>';
   // echo '<br>foundacc ' . $acc_id;
    if (!in_array($acc_id, $accsused)) {
        array_push($accsused, $acc_id);
    }

    $req = "select account_id from refuses where created > date_sub(NOW(), interval 2 minute) and account_id = "
            .$acc_id
            ." and main_task_id = (select parent_id from tasks where id = "
            .$taskid
            .")";
    //echo '<pre>'; var_dump($req);
    $taskrefused = mysqli_query($link, $req);
    //echo '<pre>'; var_dump($taskrefused);
    $isrefusedthistask = mysqli_fetch_array($taskrefused);/**/
    //echo '<pre>'; var_dump($isrefusedthistask);
    //die();
    if (count($isrefusedthistask) == 0)
    {
        $assigned_tasks[$taskid] = $acc_id;
        array_push($assigned_accs[$acc_id],$taskid);
    }
    //echo '<br>Assigned opentask type '.$opentask['type'].' id '.$opentask['id'].'<br>';
    return false;
}

function GrabTasksForAccount($acc_id, $status=0)
{
    global $link;
    $str = "select * from tasks where assignees_arr = $acc_id";
    if ($status != 0)
        $str .= " and status=".$status;
    $str .= " and status < 5";
    //$str = "select *,name from tasks,tasktypes where tasks.id = $task_id and tasktypes.id = tasks.type";
    $query1 = mysqli_query($link, $str);
    $tasks = array();
    while ($res1 = mysqli_fetch_array($query1)) {
        array_push($tasks, $res1);
    }
    return $tasks;
}

function GrabTasksFromGlobal($task_id)
{
//    echo 'GrabTask '.$task_id;
    global $link;
    $str = "select * from tasks where parent_id = $task_id and status=1";
    //$str = "select *,name from tasks,tasktypes where tasks.id = $task_id and tasktypes.id = tasks.type";
    $query1 = mysqli_query($link, $str);
    $tasks = array();
    while ($res1 = mysqli_fetch_array($query1)) {
        array_push($tasks, $res1);
    }
    return $tasks;
}

function GrabTask($task_id)
{
    global $link;
    $str = "select * from tasks where id = ".$task_id;
    //$str = "select *,name from tasks,tasktypes where tasks.id = $task_id and tasktypes.id = tasks.type";
    $query1 = mysqli_query($link, $str);

    if ($res1 = mysqli_fetch_array($query1)) {
        $result = sizeof($res1);
        //echo 'GrabTask '.$task_id.' size '.$result;
        return $res1;
    }
    //echo 'GrabTask res null';
    return null;
}

function GrabTasks($taskstring)
{
    global $link;
    $tasks = array();
    $task_ids = explode(',',$taskstring);
//    echo 'taskstring '.$taskstring;
    foreach ($task_ids as $task_id)
    {
        $str = "select * from tasks where id = $task_id";
        $query1 = mysqli_query($link, $str);

        if ($res1 = mysqli_fetch_array($query1)) {
            array_push($tasks, $res1);
        }
    }
    return $tasks;
}

function GrabSubTasks($parent_id)
{
    global $link;
    $subtasks = array();
    $str = "select * from tasks where parent_id = $parent_id";
    $query1 = mysqli_query($link, $str);

    while ($res1 = mysqli_fetch_array($query1)) {
        array_push($subtasks, $res1);
    }

    return $subtasks;
}


function GrabOpenTasks($flag = 'all')
{
    if ($flag == 'subtasks')
        $add = ' and parent_id > 0';
    else
        $add = ' and parent_id = 0';

    global $link, $companyID;
    //$str = "select * from tasks where status = 1";
    $str = "select t.* from tasks t join projects_locotech p on t.input_id = p.id and p.company=$companyID where t.status = 1";
//    echo $str;
    //echo "opentasks $str<br>";
    $query1 = mysqli_query($link, $str.$add);
    $alltasks = array();
    while ($res1 = mysqli_fetch_assoc($query1)) {
        $id = $res1['id'];
        $parent_id = $res1['parent_id'];
        //echo "parent_id $parent_id ";
        if ($flag == 'subtasks' && GrabTask($parent_id) == null)
        {
            echo "parent_id skip $parent_id<br>";
            continue;
        }
        array_push($alltasks, $res1);
        if ($flag == 'all') {  //subtasks in main select
            $subs = GrabSubTasks($id);
            $alltasks = array_merge($alltasks, $subs);
        }
    }
//    var_dump($alltasks);
    return $alltasks;
}

function GrabTasktype($id)
{
    global $link;
    $str = "select * from tasktypes where id=$id";

    $query1 = mysqli_query($link, $str);

    if ($res1 = mysqli_fetch_array($query1)) {
        return $res1;
    }
    return array();
}

function GetListFromDB($class, $key, $value, $sortby="id", $sort="ASC")
{
    global $entityManager;
    return $entityManager->getRepository($class)->findBy(array($key => $value), array($sortby => $sort));
}

function GetArrayFromDB($class, $array, $sortby="id", $sort="ASC")
{
    global $entityManager;
    return $entityManager->getRepository($class)->findBy($array, array($sortby => $sort));
}

function GrabActions($id)
{
    $actions = array();
    return $actions;
}

function CreateTasks($tasktypesarr, $input_id=0)
{
    global $link;
    //echo "CreateTasks sizetask ".sizeof($tasktypesarr);

    $maintasks = array();
    foreach ($tasktypesarr as $tasktype)
    {
        /**
         * @var Tasktype $tasktype
         */
        if ($tasktype->main_task == '1')
        {
            $tid = $tasktype->id;

            $subtaskarr = explode(",", $tasktype->subtasks);
//            $subtaskarr = $tasktype->getTasktypes();

            $str = "INSERT INTO tasks (type, status, priority, created, input_id) VALUES ($tid, 1, 0, NOW(), $input_id)";
//            echo $str;
           $result = mysqli_query($link, $str);   //создание глобальной задачи

            if (mysqli_affected_rows($link) >0 )
            {
                $parent_id = mysqli_insert_id($link);
                array_push($maintasks, $parent_id);

                $priority = 1;
                
                foreach ($subtaskarr as $subid) {

                    $str = "insert into tasks (type, parent_id, priority, status, created, input_id) values ($subid, $parent_id, $priority, 1, NOW(), $input_id)";
                    $sub_id = mysqli_insert_id($link);
                    require_once 'tmc/yiiInit_once.php';
                    \app\models\ElasticLog::command((int)$sub_id);
                    //создаем парентов
                    $types = \CheckPointTypes\CheckPointType::GetCheckPointTypesByTask($subid);
                    if (sizeof($types) > 0) {
                        $q = mysqli_query($link, "select MAX(id) from tasks");
                        if ($res = mysqli_fetch_row($q))
                        {
                            $myid = intval($res[0]);
                            foreach ($types as $typeID) {
//                                echo "create type " . $typeID['cp_type_id'];
                                //var_dump($typeID['cp_type_id']);die();
                                $cpt = \CheckPointTypes\CheckPointType::CreateFromID($typeID['cp_type_id']);
                                if ($cpt != null)
                                    $cp = \CheckPoints\CheckPoint::CreateFromType($cpt, null, $myid+1);
                            }
                        }
                    }

                    mysqli_query($link, $str);   //создание подзадач
                    $priority++;
                }
            }

        }
    }
    if (sizeof($maintasks) > 0) {
        //echo " <span style='color: green'>Задачи созданы для проекта $input_id!</span>";
        $taskstring = implode(",",$maintasks);
        AddTasksToProject($taskstring, $input_id);
    }
//    else
//        echo '<span style="color: red;"> Нет ни одной основной задачи!</span><br>';
}

function AddTasksToProject($taskstring, $input_id)
{
    global $link;
    $str = "update projects_locotech set tasks = '$taskstring' where id= $input_id";
    mysqli_query($link, $str);
}

function GrabTasktypesStringFromAction($actionid)
{
    global $link;
    $str = "select tasktypes from project_types where id=$actionid";
    $query1 = mysqli_query($link, $str);
    $ret = array();
    if ($res1 = mysqli_fetch_row($query1))
    {
        $ret = $res1[0];
    }
    return $ret;
}


//получить сабтаски по компании
//получить таски по компании
//получить и таски и сабтаски по компании

function GrabTasktypes($chooseSubtasks = "all")
{
    global $link, $companyID, $entityManager;
    //$list = GetListFromDB('Tasktype', 'company', $companyID, 'id', 'DESC');
    $str = "SELECT t FROM Tasktype t";    //DOCTRINE
    $str .= " WHERE t.company=$companyID";
    if ($chooseSubtasks == "subs")
        $str .= " and t.main_task = 0";
    else if  ($chooseSubtasks == "tasks")
        $str .= " and t.main_task = 1";

    //$str .= ' ORDER BY t.name ASC';
    $str .= ' ORDER BY t.id DESC';

    $query = $entityManager->createQuery($str);
    $list = $query->getResult();
    return $list;
}

function GrabTasktypesIDs($chooseSubtasks = "all")
{
    global $link, $companyID, $entityManager;
    //$list = GetListFromDB('Tasktype', 'company', $companyID, 'id', 'DESC');
    $str = "SELECT t.id FROM Tasktype t";    //DOCTRINE
    $str .= " WHERE t.company=$companyID";
    if ($chooseSubtasks == "subs")
        $str .= " and t.main_task = 0";
    else if  ($chooseSubtasks == "tasks")
        $str .= " and t.main_task = 1";

    $str .= ' ORDER BY t.id DESC';

    $query = $entityManager->createQuery($str);
    $list = $query->getResult();
    $ids = array();
    foreach ($list as $el)
        array_push($ids, $el['id']);
    return $ids;
}


function getCurrentDeviceId($accountId)
{
    global $link;
    $did = 0;
    $query = mysqli_query($link,"select active_device_id from accounts where id = $accountId");
    if ($query && $res = mysqli_fetch_row($query))
    {
        $did = intval($res[0]);
    }
    return $did;
}

function LogOff()
{

}

function getActiveSession($accountId)
{
    global $link;
    $sid = 0;
    $query0 = mysqli_query($link,"select MAX (id) from sessions where account_id = ". $accountId);
    if ($query0 && $res = mysqli_fetch_row($query0))
    {
        $sid = intval($res[0]);
    }
    if ($sid)
    {
        $query = mysqli_query($link,"select start, device_id from sessions where id=".$sid);
        if ($query && $res = mysqli_fetch_row($query))
        {
            $start = $res[0];
            $did = intval($res[1]);
        }
    }
    return array("id"=>$sid, "start"=>$start, "device_id"=>$did);
}

function getProjectByTask($taskId)
{
    global $link;
    $query = mysqli_query($link,"select input_id from tasks where id = ".$taskId);
    if ($query && $res = mysqli_fetch_array($query))
    {
        return GetProject($res['input_id']);
    }
    return null;
}

function getProjectsByAction($actionId)
{
    global $link;
    $str = "select * from projects_locotech where action = $actionId";
    $query1 = mysqli_query($link, $str);
    $projarr = array();
    while ($res1 = mysqli_fetch_array($query1)) {
        array_push($projarr, $res1);
    }
    return $projarr;
}

function getProjectIDByTask($taskId)
{
    global $link;
    //$query = mysqli_query($link,"select * from tasktypes tt INNER JOIN tasks t ON t.type = tt.id");
    $query = mysqli_query($link,"select input_id from tasks where id = ".$taskId);
    $pid = 0;
    if ($query && $res = mysqli_fetch_array($query))
    {
        $pid = intval($res['input_id']);
    }
    return $pid;
}

function getCompanyByTask($taskId)
{
    global $link;
    //$query = mysqli_query($link,"select * from tasktypes tt INNER JOIN tasks t ON t.type = tt.id");
    $query = mysqli_query($link,"select * from tasktypes tt, tasks t where t.type = tt.id and t.id = ".$taskId);

    if ($query && $res = mysqli_fetch_array($query))
    {
        $companyid = intval($res['company']);
    }
    return getCompanyByID($companyid);
}

function getCompanyByAccount($accountId)
{
    global $link;
	$query = mysqli_query($link,"select company from accounts where id = $accountId");
	if ($query && $res = mysqli_fetch_array($query)) {
		$companyid = intval($res['company']);		
	}
	return getCompanyByID($companyid);
}

function getCompanyByID($companyid) 
{
    global $link;
	$query = mysqli_query($link,"select name, logo from companies where id = $companyid");
	if ($query && $res = mysqli_fetch_array($query))
	{
		$mycompany = $res['name'];
                $mycompanylogo = $res['logo'];
	}
	return array($companyid, $mycompany, $mycompanylogo);
}

$oses = "WinPhoneWinXPMacOSLinuxUbuntuiPhoneiPodiPadAndroidBlackBerryMobile";
function getOS() 
{ 
	$user_agent     =   $_SERVER['HTTP_USER_AGENT'];
	//echo "user_agent ".$user_agent;
	$os_platform    =   "Unknown OS Platform";
	$os_array       =   array(
						'/ARM/i'     =>  'WinPhone',
                    '/windows nt 5.2/i'     =>  'WinXP',
                    '/windows nt 5.1/i'     =>  'WinXP',
                    '/windows xp/i'         =>  'WinXP',
						'/windows/i'     =>  'Windows',							
                    '/macintosh|mac os x/i' =>  'MacOS',
                    '/mac_powerpc/i'        =>  'MacOS',
                    '/linux/i'              =>  'Linux',
                    '/ubuntu/i'             =>  'Ubuntu',
                    '/iphone/i'             =>  'iPhone',
                    '/ipod/i'               =>  'iPod',
                    '/ipad/i'               =>  'iPad',
                    '/android/i'            =>  'Android',
                    '/blackberry/i'         =>  'BlackBerry',
                    '/webos/i'              =>  'Mobile'    						
						
//                            '/windows nt 10/i'     =>  'Windows 10',
//                            '/windows nt 6.3/i'     =>  'Windows 8.1',
//                            '/windows nt 6.2/i'     =>  'Windows 8',
//                            '/windows nt 6.1/i'     =>  'Windows 7',
//                            '/windows nt 6.0/i'     =>  'Windows Vista',
//                            '/windows nt 5.2/i'     =>  'Windows Server 2003/XP x64',
//                            '/windows nt 5.1/i'     =>  'Windows XP',
//                            '/windows xp/i'         =>  'Windows XP',
//                            '/windows nt 5.0/i'     =>  'Windows 2000',
//                            '/windows me/i'         =>  'Windows ME',
//                            '/win98/i'              =>  'Windows 98',
//                            '/win95/i'              =>  'Windows 95',
//                            '/win16/i'              =>  'Windows 3.11',
//                            '/macintosh|mac os x/i' =>  'Mac OS X',
//                            '/mac_powerpc/i'        =>  'Mac OS 9',
//                            '/linux/i'              =>  'Linux',
//                            '/ubuntu/i'             =>  'Ubuntu',
//                            '/iphone/i'             =>  'iPhone',
//                            '/ipod/i'               =>  'iPod',
//                            '/ipad/i'               =>  'iPad',
//                            '/android/i'            =>  'Android',
//                            '/blackberry/i'         =>  'BlackBerry',
//                            '/webos/i'              =>  'Mobile'
                );


	foreach ($os_array as $regex => $value) 
	{ 
		if (preg_match($regex, $user_agent))
		{
			$os_platform    =   $value;
			return $os_platform;
		}
	}
}

function GetTaskStatusFromID($taskid)
{
    $task = GrabTask($taskid);
    $parent = intval($task['parent_id']);
    if ($parent > 0)
        return intval($task['status']);
    else
    {
        $tasks = GrabSubTasks($taskid);
        $assigned = 0;
        $accepted = 0;
        $hold = 0;
        $done = 0;
        $lentasks = sizeof($tasks);
        foreach ($tasks as $task)
        {
            $status = intval($task['status']);
            switch ($status) {
                case 2:
                    $assigned++;
                    break;
                case 3:
                    $accepted++;
                    break;
                case 4:
                    $hold++;
                    break;
                case 5:
                    $done++;
                    break;
            }
        }
        if ($done == $lentasks && $lentasks > 0)
        {
            return 5;
        }
        elseif ($accepted > 0 || $assigned > 0)
        {
            return 2;
        }
        else
            return 1;
    }
}

function GetTaskStatus($taskid)
{
    $task = GrabTask($taskid);
    $parent = intval($task['parent_id']);
    if ($parent > 0)
        return intval($task['status']);
    else
    {
        $tasks = GrabSubTasks($taskid);
        $assigned = 0;
        $accepted = 0;
        $hold = 0;
        $done = 0;
        $lentasks = sizeof($tasks);
        foreach ($tasks as $task)
        {
            $status = intval($task['status']);
            switch ($status) {
                case 2:
                    $assigned++;
                    break;
                case 3:
                case 6:
                case 7:
                    $accepted++;
                    break;
                case 4:
                    $hold++;
                    break;
                case 5:
                    $done++;
                    break;
            }
        }
        if ($done == $lentasks && $lentasks > 0)
        {
            return 5;
        }
        elseif ($accepted > 0)
        {
            return 2;
        }
        elseif ($assigned > 0)
            return 2;
        else
            return 1;
    }
}

function GetProjectStatus($projid)
{
    //$proj = GetProject($projid);
    /**
     * @var $proj Project
     */
    $proj = Project::Find($projid);
    $tasks = $proj->getTasks();
    //$tasks = GetTasksForProject($projid);
    $assigned = 0;
    $accepted = 0;
    $hold = 0;
    $done = 0;
    $numcommands = 0;
    $lentasks = 0;
    foreach ($tasks as $task)
    {
     //   if ($task['parent_id']=='0') {
        if ($task->parent_id==0) {
            $lentasks++;
            $numcommands++;
            //$status = intval($task['status']);
//            $status = GetTaskStatus($task['id']);
            switch ($task->status) {
                case 2:
                    $assigned++;
                    break;
                case 3:
                    $accepted++;
                    break;
                case 4:
                    $hold++;
                    break;
                case 5:
                    $done++;
                    break;
            }
        }
    }
    //echo $lentasks;
    if ($done == $lentasks && $lentasks > 0)
    {
        return 5;
    }
    elseif ($done > 0)
    {
        return 2;
    }
    elseif ($accepted > 0 || $assigned > 0)
    {
        return 2;
    }
    else
        return 1;
}
function ASUSG($asusg_job_mapped_id)
{
    global $link;
    $query = mysqli_query($link, "select * from asusg_job2launch where id=$asusg_job_mapped_id");

    $taskarr = array();
    while ($query && $res = mysqli_fetch_assoc($query))
    {
        array_push($taskarr, $res);
    }
    return $taskarr;
}

function TaskStatusSet($taskid, $status, $confirmdata = '', $main = 0)
{
    global $link;
    if ($status == '5') {
        $finished = ", finished_time=NOW()";
    }
    if ($confirmdata != '')
        $conf = ", confirm_data ='$confirmdata'";

    mysqli_query($link, "update tasks set status = $status$finished$conf  where id=$taskid");
    $proj = getProjectByTask($taskid);
    $project_id = intval($proj['id']);
    if (($main && $status == '5') || $status == '2' || $status == '3')
    {
        /**
         * @var $proj Project
         */
        if ($project_id > 0) {
            $proj = Project::Find($project_id);
            if ($proj != null) {
                OCStaskstatus($taskid, $status, 0);
                $proj->setStatus($status);
                $proj->Save();
                if ($status == 5)
                    $proj->AddCompletedWork();
            }
        }
    }
//        mysqli_query($link, "update projects_locotech set status = $status where id=".$proj['id']);
}

function WriteLog($accid, $text='')
{
    global $link;
    $text = urldecode($text);
    $str = "INSERT into text_log (msg, stamp) values ('$accid: $text',NOW())";
    mysqli_query($link, $str);
}


//0 = неудача основная причина, 1 - успех, 2 - неудача по зоне, 3 - неудача таймаут, 4 - неудача по ТМЦ (объект)
function TaskConfirmCheck(Task $task, $zoneId)
{
    global $link;
    if (!$task) {
        WriteLog("TaskConfirmCheck task not found", "");
        return 0;
    }
    /**
     * @var $tasktype Tasktype
     */
    $tasktype = Tasktype::Find($task->type);


    try {
        $company = Company::Find($tasktype->company);
        if ($company)
        {
            $timeout = $company->GetConfirmTimeout();
            $accepted = TimeString($task->accepted_time);
            $time = ($timeout+strtotime($accepted));

            if (time() < $time) {
                WriteLog("TaskConfirmCheck task $task->id timeout fail, time:", $time);
                return 3;
            }
        }
    } catch (\Throwable $e) {
        echo $e->getMessage();
    }


    $objtype = $tasktype->object_type;
    $tmcId = FindTMCId($objtype);

    $proj = $task->project;//getProjectByTask($tid);


    $taskid = $task->GetId();
    $confirmtype = getConfirmTypebyTask($taskid);
    $result = 1;
    switch ($confirmtype)
    {
        case 2:    //Скан QR кода, пришедшего с объектом - доверяем клиенту
            break;
        case 8: //picture
            $imgpath = GetImagePathFromTask($task);
            $files1 =  scandir($imgpath);
            $len = sizeof($files1);
            if ($len <= 2)  //dots
            {
                //echo "TaskConfirmCheck images false";
                WriteLog("TaskConfirmCheck task $task->id failed image: ", $len);
                $result = 0;
            }
            break;
        case 9:  //text or audio note
            $notes = FindTaskNotes($taskid);
            if (sizeof($notes) == 0)
            {
                //echo "TaskConfirmCheck notes false";
                WriteLog("TaskConfirmCheck task $task->id failed notes: ", sizeof($notes));
                $result = 0;
            }
            break;
        case 12:    //control map
            require_once "server.php";
            $task->control_map_checked = TaskControlMapCheck($taskid);

            $task->save();
//            var_dump($task->control_map_checked);
            if (intval($task->control_map_checked) != 1) {
                WriteLog("TaskConfirmCheck task $task->id failed control map: ",intval($task->control_map_checked));
                $result = 0;
            }
            break;
        case 13:    //масломер
            if (intval($tmcId) > 0 && isset($proj)) {
                $section = $task->getSection();
//        WriteLog("TaskConfirmCheck request sec id $section->id ", isset($proj));
                if ($section) {
                    require_once("curlexec.php");
                    $str = "http://oiltest.prmsys.net/api/session/finish?deviceId=$tmcId&sectionId=$section->id";
//            WriteLog("TaskConfirmCheck request string ", $str);
                    $response = CURLrequestGET($str, ["uuid-key: 07a13c8907d1-6a7bdba1-a2fz-aatgu4j"]);
                    WriteLog("TaskConfirmCheck request response ", $response);
                    if (intval($response) > 0) {
                        WriteLog("TaskConfirmCheck task $task->id failed with oil tmc, api response: ", $response);
                        return 4;
                    }
                }
            }
            break;
        case 14:
            $zone_req= $tasktype->zone_required_id;
            if ($zone_req && $zoneId != $zone_req)
                $result = 2;
            break;
        case 17:    //AR object recognized
            $str = "select ar_object_id from tasks where id=$taskid";
            $query = mysqli_query($link, $str);
            if ($result = mysqli_fetch_object($query)) {
                if (!$result->ar_object_id)
                    $result = 0;
            }
            break;
        case 18:    //smart contract
            global $host, $port;
            WriteLog(666, "18!!!");
            if (CheckConnection())
                readfile("http://$host:$port/WebAPI/1");
            break;
    }
    //WriteLog("workToExecute =>1", 'start'.$taskid);
    $exec = \app\models\MappingworksModel::workToExecute($taskid);
    //WriteLog("workToExecute =>2", $exec);
    //if ( false == $exec) {
    //    $result = 0;
    //}
    //echo "TaskConfirmCheck tid $taskid ctype $confirmtype result $result path $imgpath fileslen $len ";
    return $result;
}
//SERVER FUNCTIONS

function GetLastZoneId($accId, $echo=false)
{
    global $link;
    $str = "SELECT * from user_positions where acc_id=$accId and DATE_ADD(ts, INTERVAL 1 minute) > now() order by id desc limit 1";
    $result_pos = mysqli_query($link, $str);
    if ($obj = mysqli_fetch_object($result_pos)) {
        $location_id = $obj->location_id;
        $x = $obj->coord_x;
        $y = $obj->coord_y;
    }
    //scale 1 зоны = 10 клеткам x1 z1 - position, x2 z2 - scale
    //координаты юзеров сейчас увеличены в
    //x/10 < x1+x2 && x/10 > x1-x2 &&
    $str = "SELECT * from zones where ($x < x1+x2*5) and ($x > x1-x2*5) and ($y < z1+z2*5) and ($y > z1-z2*5) and location_id=$location_id limit 1";
    WriteLog($accId, $str);
    if ($echo)
    {
        echo $str;
    }
    $result_zones = mysqli_query($link, $str);
    if ($obj = mysqli_fetch_object($result_zones)) {
        $zone_id = $obj->id;
        $desc = $obj->description;
        return $zone_id;
    }
    return 0;
}

function GetZoneName($zone_id)
{
    global $link;
    $str = "SELECT description from zones where id=$zone_id";
    $result_pos = mysqli_query($link, $str);
    if ($obj = mysqli_fetch_object($result_pos)) {
        return $obj->description;
    }
    return "";
}

function IsMeasurement($task_id)
{
    global $link;
    $str = "SELECT * from asusg_measurements where smopp_task_id=$task_id order by id desc  limit 1";
    $result_pos = mysqli_query($link, $str);
    if ($obj = mysqli_fetch_object($result_pos)) {
        //WriteLog("IsMeasurement task $task_id", "true");
        return $obj;
    }
    WriteLog("IsMeasurement task $task_id", "false");
    return null;
}

function Measurements2JSON($proj_id)
{
    global $link;
    $work_id = 0;
    $user_id = 0;
    $jsonStringReturn = array();
    $measurements = array();
    $str = "SELECT mes.* from tasks as t join asusg_measurements as mes on mes.smopp_task_id=t.id where t.input_id=$proj_id";
    $result_pos = mysqli_query($link, $str);
    while ($obj = mysqli_fetch_object($result_pos)) {
        if (!$work_id)
            $work_id = $obj->work_id;
        if (!$user_id)
            $user_id = json_decode($obj->worker)->id;

        $measurement = [];
        $measurement['measurement_id'] = $obj->measurement_id;
        $measurement['characteristic_id'] = $obj->characteristic_id;
        $measurement['measurement_stage'] = $obj->measurement_stage;
        $measurement['measurement_value'] = $obj->measurement_value;
        $measurement['comment'] = json_decode($obj->measurement_comment)->text;
        $measurements[] = $measurement;
    }
    $jsonStringReturn['user_id'] = $user_id;
    $jsonStringReturn['work_id'] = $work_id;
    $jsonStringReturn['measurements'] = $measurements;
    return $jsonStringReturn;
}

function Measurements2JSONTask($task_id, $user_id, $ignore_hardware = true)
{
    global $link;
    $work_id = 0;
    $jsonStringReturn = array();
    $measurements = array();
    $str = "SELECT mes.* from tasks as t join asusg_measurements as mes on mes.smopp_task_id=t.id where t.id=$task_id";
    $result_pos = mysqli_query($link, $str);
    while ($obj = mysqli_fetch_object($result_pos)) {
        if ($ignore_hardware && intval($obj->is_hw_measurement)>0)
            continue;
        if (!$work_id)
            $work_id = $obj->work_id;
        if (!$user_id)
        {
            $user_id = json_decode($obj->worker)->id;
        }

        if ($obj->value_type == 'boolean')
        {
            $obj->measurement_value = $obj->measurement_value == 1 ?true:false;
        }

        $measurement = [];
        $measurement['measurement_id'] = $obj->measurement_id;
        $measurement['characteristic_id'] = $obj->characteristic_id;
        $measurement['measurement_stage'] = $obj->measurement_stage;
        $measurement['measurement_value'] = $obj->measurement_value;
        $measurement['comment'] = json_decode($obj->measurement_comment)->text;
        $measurements[] = $measurement;
    }
    $jsonStringReturn['user_id'] = $user_id;
    $jsonStringReturn['work_id'] = $work_id;
    $jsonStringReturn['measurements'] = $measurements;
    return $jsonStringReturn;
}

function WriteMeasurementsToTWX($dict)
{
    require_once 'curlexec.php';
    //$url = "http://devplatform.digitaldepot.ru:8085/Thingworx/Things/2050UserLibraryExp/Services/write_work_measurements_v2";
    //$result = CURLrequestPOST($url, ["AppKey: 6a7bdbaa-6bc1-4159-a2f4-07a13c8907d1"], $dict);

    $url = "http://qaplatform.digitaldepot.ru:8085/Thingworx/Things/2050UserLibraryExp/Services/write_work_measurements_v2";
    $result = CURLrequestPOST($url, ["AppKey: 33cd23bb-3b03-4638-afef-7104a13e9211"], $dict);
    WriteLog("WriteMeasurementsToTWX input ".json_encode($dict), $result);
}



function TaskConfirm($num, $id, $tid, $confirm_data, $verbose=false)
{
//    try {received
    //TODO брать сабтаски из их таблицы по исполнителю
    ob_start();
    global $link, $companyID;
    /**
     * @var $task Task
     */
    $task = Task::Find($tid);
    if ($task != null) {
        $accid = intval($task->assignees_arr);
        if ($accid != intval($id))
        {
            TaskConfirmResult($num, 0, $tid);
            EnqueueCMD($id, "21");
            WriteLog("TaskConfirm task $tid failed account id $id != ",$accid);
            return;
        }

        if (intval($task->status) == 5)
        {
            TaskConfirmResult($num, 1, $tid);
            WriteLog("TaskConfirm task $tid failed status already ",$task->status);
            return;
        }
        $zoneId = GetLastZoneId($id);
        $checkresult = TaskConfirmCheck($task, $zoneId);
        if ($verbose)
            echo "result $checkresult";

        if ($checkresult != 1) {
            TaskConfirmResult($num, $checkresult, $tid);
            return;
        }

        /**
         * @var $account Account
         */
        $account = Account::Find($id);
        if ($account != null) {
            $tasks = $account->tasks;
            $account->last_action = new \DateTime("now");
            $account->Save();

            $companyID = $account->getCompany()->id;

            $measurement = IsMeasurement($tid);
            if ($measurement)
            {
                    //TODO понять что таск записан - тогда слать тру
                    $task_hw = $task->asusg_task_hw_measurement_id;
                    if ($task_hw)
                    {
                        if (intval($task->status) != 7) {
                            TaskConfirmResult($num, 0, $tid);
                            WriteLog("TaskConfirm task $tid failed status is ", $task->status);
                            return;
                        }
                    }
                $json = Measurements2JSONTask($tid, $account->uuid);
                \app\models\entity\Metrics::log(2, $num, 'write_work_measurements_v2, workId = ' . ($json['work_id'] ?? 0));
                WriteMeasurementsToTWX($json);
                \app\models\entity\Metrics::log(3, $num, 'write_work_measurements_v2, workId = ' . ($json['work_id'] ?? 0));
            }
            else
            {
                $subs = explode(" ",$task->name);
                if ($subs[0] === "Замер")
                {
                    TaskConfirmResult($num, 0, $tid);
                    return;
                }
            }
            mysqli_query($link, "update tasks set status=5, zone_id = $zoneId, finished_time = NOW() where id=$tid");
            \app\models\ElasticLog::command((int)$task->id, 'Завершение');
            $parenttask = Task::Find($task->parent_id);
            $subtasks = GrabSubTasks($parenttask->id);
            $numconfirmed = 0;

            foreach ($subtasks as $sub) {
                $status = intval($sub['status']);
                $subtask = Task::Find($sub['id']);
//                \Doctrine\Common\Util\Debug::dump($subtask);

                if ($status == 5 && $tasks->contains($subtask)) {
                    $numconfirmed++;
                }
            }

            if ($verbose)
            {
                var_dump($numconfirmed);
                var_dump(sizeof($subtasks));
            }
            if ($numconfirmed == sizeof($subtasks)) {
                $parenttask->status = 5;
                $parenttask->Save();
                $proj = $parenttask->project;
                if ($verbose)
                    \Doctrine\Common\Util\Debug::dump($proj);
                if ($proj != null) {
//write entire project
//                    if (IsMeasurement($tid))
//                    {
//                        $json = Measurements2JSON($proj->id);
//                        WriteMeasurementsToTWX($json);
//                    }
                    $proj->finished_time = new \DateTime("now");;
                    $proj->setStatus(GetProjectStatus($proj->id));
                    if ($verbose)
                        var_dump($proj->getStatus());
                    $proj->Save();

                    //временный хардкод - ПРИЕМКА создает опись
                    TempStartProject($proj);
                }
                TasksAssign('', true, 0, false);
            }
            WriteLog("TaskConfirm success $tid account id $accid","");
            OCStaskstatus($tid, 5, $accid);
            TaskConfirmResult($num, 1, $tid);
//            $buf = pack("C", $num);
//            $buf .= pack("Cl*", 1, $tid);
//            ob_get_clean();
//            echo base64_encode($buf);
        }
    }
//    } catch (\Throwable $e) {
//        echo $e->getMessage();
//    }

}

function TaskConfirmResult($num, $res, $tid)
{
    \app\models\entity\Metrics::log(4, $num, 'taskId = ' . $tid);
    $buf = pack("C", $num);
    $buf .= pack("Cl*", $res, $tid);
    ob_get_clean();
    echo base64_encode($buf);
}

/**
 * Проверяет есть ли секция с заданными параметрами, если нет, то создаёт её.
 * Обновляет диагностическую карту
 *
 * @param $letter
 * @param $series
 * @param $number
 * @param $subnumber
 */
function CheckSection($letter, $series, $number, $subnumber)
{
    if ($subnumber) {
        global $entityManager;
        $sec = $entityManager->getRepository('Section')->findBy([
            'locomotive_series' => $series,
            'section_number' => $number,
            'section_subnumber' => $subnumber,
            "letter" => $letter
        ]);
        if (sizeof($sec) > 0) {
            $section = $sec[0];
        } else {
            $series = LocoSeries::Find("$series");
            if ($series != null) {
                $section = new Section();
                $section->letter = $letter;
                $section->series = $series;
                $section->setSectionSubnumber($subnumber);
                $section->setSectionNumber($number);
            }
        }
        if ($section != null) {
            UpdateDiagnosticMap($section, true);
        }
    }
}

function UpdateDiagnosticMap(Section $section, $save = false)
{
    $params['subnum_section'] = $section->getSectionSubnumber();
    $locomotiveModel = new app\models\LocomotiveModel();
    $result = $locomotiveModel->getSectionInfo($params);
    $json = json_decode($result);
    if ($json != null && $json->diagnosticMap != null) {
        $uuid = $json->diagnosticMap;
        $section->uuid = $json->section_id;
        $mynum = $json->section_num;    //letter == last symbol
        $letter = substr($mynum, -1);
        if (intval($letter) <= 0)
            $section->letter = $letter;
        $existed = DiagnosticMap::Find($uuid);
        if ($existed == null) {
            $dm = new DiagnosticMap();
            $dm->created = new DateTime("now");
            $dm->uuid = $uuid;
            $section->addDiagnosticMap($dm);
            $section->diagnostic_map = $uuid;
        }
    }
    if ($save)
        $section->Save();
}

function CreateProject($projecttype, $loco_number, $loco_type, $А, $Б, $В, $Г)
{
    global $link, $companyID;

        CheckSection("А", $loco_type, $loco_number, $А);
        CheckSection("Б", $loco_type, $loco_number, $Б);
        CheckSection("В", $loco_type, $loco_number, $В);
        CheckSection("Г", $loco_type, $loco_number, $Г);

        $qstr = "insert into projects_locotech (action, company, status, loco_type,loco_number,depo,depo_service, created, urgent) values ($projecttype, $companyID,1,'$loco_type',$loco_number,'','', NOW(), 0)";
        mysqli_query($link, $qstr);
        $activeid = mysqli_insert_id($link);

        if ($activeid) {
            if (StartProject($projecttype, $activeid))
                TasksAssign('', true, $activeid);
        }
}

function TempStartProject($proj = null)
{
    global $link, $companyID;
    $projecttype = $proj->getAction();
//    var_dump($projecttype);
    if ($projecttype == 187 || $projecttype == 185 || $projecttype == 170 || $projecttype == 178) {
        if ($proj->getStatus() == 5) {
            $loco_number = $proj->loco_number;
            $loco_type = $proj->getLocoType();
            $qstr = "insert into projects_locotech (action, company, status, loco_type,loco_number,depo,depo_service, created, urgent) values (" . 214 . "," . 3 . ",1,'$loco_type','$loco_number','','', NOW(), 0)";
            mysqli_query($link, $qstr);
            $activeid = mysqli_insert_id($link);

//            var_dump($activeid);
            if ($activeid) {
                $project = Project::Find($activeid);
                if ($project != null) {
                    /**
                     * @var $project Project
                     */
                    if ($proj->section) {
                        $project->section = $proj->section;
                        $project->Save();
                    }
                }
                if (StartProject(214, $activeid))
                    TasksAssign('', true, $activeid);
            }
            //временный хардкод - ПРИЕМКА создает опись
        }
    }
}
//            if (StartProject($action_num, $activeid))
//                TasksAssign('', true, $assign_id);
function GrabReadyTasksForAccount($accid, $typeid)
{
    global $link;
    $query = mysqli_query($link, "select * from tasks where status = 5 and type = $typeid and assignees_arr=".$accid);
    $taskarr = array();
    while ($query && $res = mysqli_fetch_array($query))
    {
        array_push($taskarr, $res);
    }
    return $taskarr;
}

function GetAverageTime($taskarr)
{
    $sum = 0;
    foreach ($taskarr as $res)
    {
        $time = TimeSpentForTaskFromArray($res);
        $sum += $time;
    }
    $sum /= sizeof($taskarr);
    $sum = round($sum, 0, PHP_ROUND_HALF_UP);
    if ($sum > 120)
        $sum = '---';
    return $sum;
}

function EfficiencyReport($accid)
{
    global $link;
    $query = mysqli_query($link, "select * from tasks where status = 5 and assignees_arr=".$accid);
    $taskarr = array();
    $retarr = array();
    
    while ($query && $res = mysqli_fetch_array($query))
    {
        $timespent = TimeSpentForTaskFromArray($res);
        $typeid = $res['type'];
        if (sizeof($taskarr[$typeid]) == 0) {
            $taskarr[$typeid] = array();
            }
        array_push($taskarr[$typeid], $timespent);
    }
    foreach ($taskarr as $type_id=>$timesspent)
    {
        $sum = 0;
        foreach ($timesspent as $time) {
            $sum += $time;
        }
        //echo "time $time";
        $sum /= sizeof($time);
        if ($sum > 120)
            $sum = '---';
        $retarr[$type_id] = $sum;
    }
    return $retarr;
}

/**
 * @param string $action Acceptable values are `encrypt` or `decrypt`.
 * @param string $string The string value to encrypt or decrypt.
 * @return string
 */
function encrypt_decrypt($action, $string)
{
    $output = false;

    $encrypt_method = "AES-256-CBC";
    $secret_key = '202cb962ac59075b964b07152d234b70';
    $secret_iv = '289dff07669d7a23de0ef88d2f7129e7';

    // hash
    $key = hash('sha256', $secret_key);

    // iv - encrypt method AES-256-CBC expects 16 bytes - else you will get a
    // warning
    $iv = substr(hash('sha256', $secret_iv), 0, 16);

    if ($action == 'encrypt') {
        $output = openssl_encrypt($string, $encrypt_method, $key, 0, $iv);
        $output = base64_encode($output);
    } elseif ($action == 'decrypt') {
        $output = openssl_decrypt(base64_decode($string), $encrypt_method, $key, 0, $iv);
    }

    return $output;
}