Тип задачи: $tasktype_id
Описание: $desc
Тип подтверждения: $confirmname
$taskid. Создана $created_time
Выдана: $assigned
Зона выполнения: $zone ($zonename) $zonestring
Зона выполнения требуемая: $zone_req ($zone_req_name)
$statusname[0]
Вы можете удалить
или отозвать эту задачу,
если что-то пошло не так.
"; echo "
Замечание: $tn->text"; } } } echo "
';
echo '
Текстовые заметки:
"; foreach ($notes as $note) { if (!$note['checkpoint_id']) { $notedate = $note['date']; $noteid = $note['id']; $notetext = $note['text']; echo "$noteid. [$taskname] $notetext
"; } } echo '
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) { ?>
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 "";
foreach ($action_data as $val) {
if ($val->id == $c_action)
$sel = 'selected';
else
$sel = '';
echo "";
}
}
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 "Должность добавлена!'; var_dump($req);
$taskrefused = mysqli_query($link, $req);
//echo ''; var_dump($taskrefused);
$isrefusedthistask = mysqli_fetch_array($taskrefused);/**/
//echo ''; var_dump($isrefusedthistask);
//die();
if (count($isrefusedthistask) == 0)
{
$assigned_tasks[$taskid] = $acc_id;
array_push($assigned_accs[$acc_id],$taskid);
}
//echo '
Assigned opentask type '.$opentask['type'].' id '.$opentask['id'].'
';
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
";
$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
";
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 " Задачи созданы для проекта $input_id!";
$taskstring = implode(",",$maintasks);
AddTasksToProject($taskstring, $input_id);
}
// else
// echo ' Нет ни одной основной задачи!
';
}
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§ionId=$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;
}