github/dootask
1
0
Fork 0
mirror of https://github.com/kuaifan/dootask.git synced 2026-01-26 20:48:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

perf 工作流接口优化

Browse Source
This commit is contained in:
ganzizi 2023-04-13 09:43:02 +08:00
parent 0f5eb829c6
commit 5923b6169a
1 changed files with 23 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
app/Http/Controllers/Api/WorkflowController.php
View File

@ -64,9 +64,9 @@ class WorkflowController extends AbstractController
{
$data['name'] = Request::input('name');
$procdef = Ihttp::ihttp_post($this->flow_url.'/api/v1/workflow/procdef/findAll', json_encode($data));
$procdef = json_decode($procdef['data'] ?? '', true);
if (!$procdef || $procdef['status'] != 200) {
return Base::retError($procdef['message'] ?? '查询流程失败');
$procdef = json_decode($procdef['ret'] == 1 ? $procdef['data'] : '{}', true);
if (!$procdef || $procdef['status'] != 200 || $procdef['ret'] == 0) {
return Base::retError($procdef['message'] ?? '查询失败');
}
return Base::retSuccess('success', Base::arrayKeyToUnderline($procdef['data']));
}
@ -89,9 +89,9 @@ class WorkflowController extends AbstractController
{
$data['id'] = Request::input('id');
$procdef = Ihttp::ihttp_get($this->flow_url.'/api/v1/workflow/procdef/delById?'.http_build_query($data));
$procdef = json_decode($procdef['data'] ?? '', true);
$procdef = json_decode($procdef['ret'] == 1 ? $procdef['data'] : '{}', true);
if (!$procdef || $procdef['status'] != 200) {
return Base::retError($procdef['message'] ?? '删除流程失败');
return Base::retError($procdef['message'] ?? '删除失败');
}
return Base::retSuccess('success', Base::arrayKeyToUnderline($procdef['data']));
}
@ -122,9 +122,9 @@ class WorkflowController extends AbstractController
$var = json_decode(Request::input('var'), true);
$data['var'] = $var;
$process = Ihttp::ihttp_post($this->flow_url.'/api/v1/workflow/process/start', json_encode(Base::arrayKeyToCamel($data)));
$process = json_decode($process['data'] ?? '', true);
$process = json_decode($process['ret'] == 1 ? $process['data'] : '{}', true);
if (!$process || $process['status'] != 200) {
return Base::retError($process['message'] ?? '流程启动失败');
return Base::retError($process['message'] ?? '启动失败');
}
//
$process = Base::arrayKeyToUnderline($process['data']);
@ -183,7 +183,7 @@ class WorkflowController extends AbstractController
$data['userid'] = Request::input('userid');
$data['comment'] = Request::input('comment');
$task = Ihttp::ihttp_post($this->flow_url.'/api/v1/workflow/task/complete', json_encode(Base::arrayKeyToCamel($data)));
$task = json_decode($task['data'] ?? '', true);
$task = json_decode($task['ret'] == 1 ? $task['data'] : '{}', true);
if (!$task || $task['status'] != 200) {
return Base::retError($task['message'] ?? '审批失败');
}
@ -242,7 +242,7 @@ class WorkflowController extends AbstractController
$data['userid'] = Request::input('userid');
$data['proc_inst_id'] = intval(Request::input('proc_inst_id'));
$task = Ihttp::ihttp_post($this->flow_url.'/api/v1/workflow/task/withdraw', json_encode(Base::arrayKeyToCamel($data)));
$task = json_decode($task['data'] ?? '', true);
$task = json_decode($task['ret'] == 1 ? $task['data'] : '{}', true);
if (!$task || $task['status'] != 200) {
return Base::retError($task['message'] ?? '撤回失败');
}
@ -287,7 +287,7 @@ class WorkflowController extends AbstractController
$data['pageIndex'] = intval(Request::input('page'));
$data['pageSize'] = intval(Request::input('page_size'));
$process = Ihttp::ihttp_post($this->flow_url.'/api/v1/workflow/process/findTask', json_encode(Base::arrayKeyToCamel($data)));
$process = json_decode($process['data'] ?? '', true);
$process = json_decode($process['ret'] == 1 ? $process['data'] : '{}', true);
if (!$process || $process['status'] != 200) {
return Base::retError($process['message'] ?? '查询失败');
}
@ -312,9 +312,9 @@ class WorkflowController extends AbstractController
{
$proc_inst_id = Request::input('proc_inst_id');
$identitylink = Ihttp::ihttp_get($this->flow_url.'/api/v1/workflow/identitylink/findParticipant?procInstId=' . $proc_inst_id);
$identitylink = json_decode($identitylink['data'] ?? '', true);
$identitylink = json_decode($identitylink['ret'] == 1 ? $identitylink['data'] : '{}', true);
if (!$identitylink || $identitylink['status'] != 200) {
return Base::retError($identitylink['message'] ?? 'fail');
return Base::retError($identitylink['message'] ?? '查询失败');
}
return Base::retSuccess('success', Base::arrayKeyToUnderline($identitylink['data']));
}
@ -342,9 +342,9 @@ class WorkflowController extends AbstractController
$data['pageSize'] = intval(Request::input('page_size'));
$process = Ihttp::ihttp_post($this->flow_url.'/api/v1/workflow/process/startByMyself', json_encode($data));
info($process);
$process = json_decode($process['data'] ?? '', true);
$process = json_decode($process['ret'] == 1 ? $process['data'] : '{}', true);
if (!$process || $process['status'] != 200) {
return Base::retError($process['message'] ?? 'fail');
return Base::retError($process['message'] ?? '查询失败');
}
return Base::retSuccess('success', Base::arrayKeyToUnderline($process['data']));
}
@ -373,9 +373,9 @@ class WorkflowController extends AbstractController
$process = Ihttp::ihttp_post($this->flow_url.'/api/v1/workflow/process/findProcNotify', json_encode($data));
info($process);
$process = json_decode($process['data'] ?? '', true);
$process = json_decode($process['ret'] == 1 ? $process['data'] : '{}', true);
if (!$process || $process['status'] != 200) {
return Base::retError($process['message'] ?? 'fail');
return Base::retError($process['message'] ?? '查询失败');
}
return Base::retSuccess('success', Base::arrayKeyToUnderline($process['data']));
}
@ -446,9 +446,9 @@ class WorkflowController extends AbstractController
{
$data['id'] = intval($id);
$process = Ihttp::ihttp_get($this->flow_url."/api/v1/workflow/process/findById?".http_build_query($data));
$process = json_decode($process['data'] ?? '', true);
$process = json_decode($process['ret'] == 1 ? $process['data'] : '{}', true);
if (!$process || $process['status'] != 200) {
return Base::retError($process['message'] ?? 'fail');
return Base::retError($process['message'] ?? '查询失败');
}
return Base::arrayKeyToUnderline($process['data']);
}
@ -473,12 +473,12 @@ class WorkflowController extends AbstractController
public function getUserProcessParticipantById($id)
{
$data['id'] = intval($id);
$user = Ihttp::ihttp_get($this->flow_url."/api/v1/user/identitylink/findParticipant?".http_build_query($data));
$user = json_decode($user['data'] ?? '', true);
if (!$user || $user['status'] != 200) {
return Base::retError($user['message'] ?? 'fail');
$process = Ihttp::ihttp_get($this->flow_url."/api/v1/workflow/identitylink/findParticipant?".http_build_query($data));
$process = json_decode($process['ret'] == 1 ? $process['data'] : '{}', true);
if (!$process || $process['status'] != 200) {
return Base::retError($process['message'] ?? '查询失败');
}
return $user;
return $process;
}
}