1058 lines
35 KiB
PHP
Executable File
1058 lines
35 KiB
PHP
Executable File
<?php
|
||
|
||
namespace App\Http\Controllers\Api;
|
||
|
||
use App\Exceptions\ApiException;
|
||
use App\Models\AbstractModel;
|
||
use App\Models\Project;
|
||
use App\Models\ProjectColumn;
|
||
use App\Models\ProjectLog;
|
||
use App\Models\ProjectTask;
|
||
use App\Models\ProjectTaskFile;
|
||
use App\Models\ProjectUser;
|
||
use App\Models\User;
|
||
use App\Models\WebSocketDialog;
|
||
use App\Module\Base;
|
||
use Carbon\Carbon;
|
||
use Illuminate\Support\Arr;
|
||
use Request;
|
||
|
||
/**
|
||
* @apiDefine project
|
||
*
|
||
* 项目
|
||
*/
|
||
class ProjectController extends AbstractController
|
||
{
|
||
/**
|
||
* 任务统计
|
||
*/
|
||
public function statistics()
|
||
{
|
||
User::auth();
|
||
|
||
$data = [];
|
||
|
||
// 今日待完成
|
||
$between = [
|
||
Carbon::today()->startOfDay(),
|
||
Carbon::today()->endOfDay()
|
||
];
|
||
$data['today'] = ProjectTask::authData(null, true)->whereParentId(0)
|
||
->whereNull('archived_at')
|
||
->whereNull('complete_at')
|
||
->where(function ($query) use ($between) {
|
||
$query->whereBetween('start_at', $between)->orWhereBetween('end_at', $between);
|
||
})
|
||
->count();
|
||
|
||
// 超期未完成
|
||
$data['overdue'] = ProjectTask::authData(null, true)->whereParentId(0)
|
||
->whereNull('archived_at')
|
||
->whereNull('complete_at')
|
||
->whereNotNull('end_at')
|
||
->where('end_at', '<', Carbon::now())
|
||
->count();
|
||
|
||
return Base::retSuccess('success', $data);
|
||
}
|
||
|
||
/**
|
||
* 获取项目列表
|
||
*
|
||
* @apiParam {String} [all] 是否查看所有项目（限制管理员）
|
||
* @apiParam {String} [archived] 归档状态
|
||
* - all：全部
|
||
* - no：未归档（默认）
|
||
* - yes：已归档
|
||
* @apiParam {Object} [keys] 搜索条件
|
||
* - keys.name 项目名称
|
||
*
|
||
* @apiParam {Number} [page] 当前页，默认:1
|
||
* @apiParam {Number} [pagesize] 每页显示数量，默认:50，最大:100
|
||
*/
|
||
public function lists()
|
||
{
|
||
$user = User::auth();
|
||
//
|
||
$all = Request::input('all');
|
||
$archived = Request::input('archived', 'no');
|
||
//
|
||
if ($all) {
|
||
$user->identity('admin');
|
||
$builder = Project::select('projects.*');
|
||
} else {
|
||
$builder = Project::select(Project::projectSelect)->authData();
|
||
}
|
||
//
|
||
if ($archived == 'yes') {
|
||
$builder->whereNotNull('projects.archived_at');
|
||
} elseif ($archived == 'no') {
|
||
$builder->whereNull('projects.archived_at');
|
||
}
|
||
//
|
||
$keys = Request::input('keys');
|
||
if (is_array($keys)) {
|
||
$buildClone = $builder->clone();
|
||
if ($keys['name']) {
|
||
$builder->where("projects.name", "like", "%{$keys['name']}%");
|
||
}
|
||
}
|
||
$list = $builder->orderByDesc('projects.id')->paginate(Base::getPaginate(100, 50));
|
||
//
|
||
$data = $list->toArray();
|
||
if (isset($buildClone)) {
|
||
$data['total_all'] = $buildClone->count();
|
||
} else {
|
||
$data['total_all'] = $data['total'];
|
||
}
|
||
//
|
||
return Base::retSuccess('success', $data);
|
||
}
|
||
|
||
/**
|
||
* 获取一个项目信息
|
||
*
|
||
* @apiParam {Number} project_id 项目ID
|
||
*/
|
||
public function one()
|
||
{
|
||
User::auth();
|
||
//
|
||
$project_id = intval(Request::input('project_id'));
|
||
//
|
||
$project = Project::userProject($project_id);
|
||
//
|
||
return Base::retSuccess('success', $project);
|
||
}
|
||
|
||
/**
|
||
* 添加项目
|
||
*
|
||
* @apiParam {String} name 项目名称
|
||
* @apiParam {String} [desc] 项目介绍
|
||
* @apiParam {String} [columns] 列表，格式：列表名称1,列表名称2
|
||
*/
|
||
public function add()
|
||
{
|
||
$user = User::auth();
|
||
// 项目名称
|
||
$name = trim(Request::input('name', ''));
|
||
$desc = trim(Request::input('desc', ''));
|
||
if (mb_strlen($name) < 2) {
|
||
return Base::retError('项目名称不可以少于2个字');
|
||
} elseif (mb_strlen($name) > 32) {
|
||
return Base::retError('项目名称最多只能设置32个字');
|
||
}
|
||
if (mb_strlen($desc) > 255) {
|
||
return Base::retError('项目介绍最多只能设置255个字');
|
||
}
|
||
// 列表
|
||
$columns = explode(",", Request::input('columns'));
|
||
$insertColumns = [];
|
||
$sort = 0;
|
||
foreach ($columns AS $column) {
|
||
$column = trim($column);
|
||
if ($column) {
|
||
$insertColumns[] = [
|
||
'name' => $column,
|
||
'sort' => $sort++,
|
||
];
|
||
}
|
||
}
|
||
if (empty($insertColumns)) {
|
||
$insertColumns[] = [
|
||
'name' => 'Default',
|
||
'sort' => 0,
|
||
];
|
||
}
|
||
if (count($insertColumns) > 30) {
|
||
return Base::retError('项目列表最多不能超过30个');
|
||
}
|
||
// 开始创建
|
||
$project = Project::createInstance([
|
||
'name' => $name,
|
||
'desc' => $desc,
|
||
'userid' => $user->userid,
|
||
]);
|
||
AbstractModel::transaction(function() use ($insertColumns, $project) {
|
||
$project->save();
|
||
ProjectUser::createInstance([
|
||
'project_id' => $project->id,
|
||
'userid' => $project->userid,
|
||
'owner' => 1,
|
||
])->save();
|
||
foreach ($insertColumns AS $column) {
|
||
$column['project_id'] = $project->id;
|
||
ProjectColumn::createInstance($column)->save();
|
||
}
|
||
$dialog = WebSocketDialog::createGroup(null, $project->userid, 'project');
|
||
if (empty($dialog)) {
|
||
throw new ApiException('创建项目聊天室失败');
|
||
}
|
||
$project->dialog_id = $dialog->id;
|
||
$project->save();
|
||
});
|
||
//
|
||
$data = Project::find($project->id);
|
||
$data->addLog("创建项目");
|
||
$data->pushMsg('add', $data);
|
||
return Base::retSuccess('添加成功', $data);
|
||
}
|
||
|
||
/**
|
||
* 修改项目（限：项目负责人）
|
||
*
|
||
* @apiParam {Number} project_id 项目ID
|
||
* @apiParam {String} name 项目名称
|
||
* @apiParam {String} [desc] 项目介绍
|
||
*/
|
||
public function update()
|
||
{
|
||
User::auth();
|
||
//
|
||
$project_id = intval(Request::input('project_id'));
|
||
$name = trim(Request::input('name', ''));
|
||
$desc = trim(Request::input('desc', ''));
|
||
if (mb_strlen($name) < 2) {
|
||
return Base::retError('项目名称不可以少于2个字');
|
||
} elseif (mb_strlen($name) > 32) {
|
||
return Base::retError('项目名称最多只能设置32个字');
|
||
}
|
||
if (mb_strlen($desc) > 255) {
|
||
return Base::retError('项目介绍最多只能设置255个字');
|
||
}
|
||
//
|
||
$project = Project::userProject($project_id);
|
||
if (!$project->owner) {
|
||
return Base::retError('仅限项目负责人修改');
|
||
}
|
||
//
|
||
if ($project->name != $name) {
|
||
$project->addLog("修改项目名称：{$project->name} => {$name}");
|
||
$project->name = $name;
|
||
}
|
||
if ($project->desc != $desc) {
|
||
$project->desc = $desc;
|
||
$project->addLog("修改项目介绍");
|
||
}
|
||
$project->save();
|
||
$project->pushMsg('update', $project);
|
||
//
|
||
return Base::retSuccess('修改成功', $project);
|
||
}
|
||
|
||
/**
|
||
* 修改项目成员（限：项目负责人）
|
||
*
|
||
* @apiParam {Number} project_id 项目ID
|
||
* @apiParam {Number} userid 成员ID 或 成员ID组
|
||
*/
|
||
public function user()
|
||
{
|
||
User::auth();
|
||
//
|
||
$project_id = intval(Request::input('project_id'));
|
||
$userid = Request::input('userid');
|
||
$userid = is_array($userid) ? $userid : [$userid];
|
||
//
|
||
$project = Project::userProject($project_id);
|
||
if (!$project->owner) {
|
||
return Base::retError('仅限项目负责人修改');
|
||
}
|
||
//
|
||
$deleteUser = AbstractModel::transaction(function() use ($project, $userid) {
|
||
$array = [];
|
||
foreach ($userid as $uid) {
|
||
if ($project->joinProject($uid)) {
|
||
$array[] = $uid;
|
||
}
|
||
}
|
||
$deleteRows = ProjectUser::whereProjectId($project->id)->whereNotIn('userid', $array)->get();
|
||
$deleteUser = $deleteRows->pluck('userid');
|
||
foreach ($deleteRows as $row) {
|
||
$row->exitProject();
|
||
}
|
||
$project->syncDialogUser();
|
||
$project->addLog("修改项目成员");
|
||
return $deleteUser->toArray();
|
||
});
|
||
//
|
||
$project->pushMsg('delete', null, $deleteUser);
|
||
$project->pushMsg('detail');
|
||
return Base::retSuccess('修改成功', ['id' => $project->id]);
|
||
}
|
||
|
||
/**
|
||
* 移交项目（限：项目负责人）
|
||
*
|
||
* @apiParam {Number} project_id 项目ID
|
||
* @apiParam {Number} owner_userid 新的项目负责人ID
|
||
*/
|
||
public function transfer()
|
||
{
|
||
User::auth();
|
||
//
|
||
$project_id = intval(Request::input('project_id'));
|
||
$owner_userid = intval(Request::input('owner_userid'));
|
||
//
|
||
$project = Project::userProject($project_id);
|
||
if (!$project->owner) {
|
||
return Base::retError('你不是项目负责人');
|
||
}
|
||
//
|
||
if (!User::whereUserid($owner_userid)->exists()) {
|
||
return Base::retError('会员不存在');
|
||
}
|
||
//
|
||
AbstractModel::transaction(function() use ($owner_userid, $project) {
|
||
ProjectUser::whereProjectId($project->id)->update(['owner' => 0]);
|
||
ProjectUser::updateInsert([
|
||
'project_id' => $project->id,
|
||
'userid' => $owner_userid,
|
||
], [
|
||
'owner' => 1,
|
||
]);
|
||
$project->syncDialogUser();
|
||
$project->addLog("移交项目给会员ID：" . $owner_userid);
|
||
});
|
||
//
|
||
$project->pushMsg('detail');
|
||
return Base::retSuccess('移交成功', ['id' => $project->id]);
|
||
}
|
||
|
||
/**
|
||
* 排序任务
|
||
*
|
||
* @apiParam {Number} project_id 项目ID
|
||
* @apiParam {Object} sort 排序数据
|
||
* @apiParam {Number} [only_column] 仅更新列表
|
||
*/
|
||
public function sort()
|
||
{
|
||
User::auth();
|
||
//
|
||
$project_id = intval(Request::input('project_id'));
|
||
$sort = Base::json2array(Request::input('sort'));
|
||
$only_column = intval(Request::input('only_column'));
|
||
//
|
||
$project = Project::userProject($project_id);
|
||
//
|
||
if ($only_column) {
|
||
// 排序列表
|
||
$index = 0;
|
||
foreach ($sort as $item) {
|
||
if (!is_array($item)) continue;
|
||
if (!intval($item['id'])) continue;
|
||
ProjectColumn::whereId($item['id'])->whereProjectId($project->id)->update([
|
||
'sort' => $index
|
||
]);
|
||
$index++;
|
||
}
|
||
$project->addLog("调整列表排序");
|
||
} else {
|
||
// 排序任务
|
||
foreach ($sort as $item) {
|
||
if (!is_array($item)) continue;
|
||
if (!intval($item['id'])) continue;
|
||
if (!is_array($item['task'])) continue;
|
||
$index = 0;
|
||
foreach ($item['task'] as $task_id) {
|
||
ProjectTask::whereId($task_id)->whereProjectId($project->id)->update([
|
||
'column_id' => $item['id'],
|
||
'sort' => $index
|
||
]);
|
||
ProjectTask::whereParentId($task_id)->whereProjectId($project->id)->update([
|
||
'column_id' => $item['id'],
|
||
]);
|
||
$index++;
|
||
}
|
||
}
|
||
$project->addLog("调整任务排序");
|
||
}
|
||
$project->pushMsg('sort');
|
||
return Base::retSuccess('调整成功');
|
||
}
|
||
|
||
/**
|
||
* 退出项目
|
||
*
|
||
* @apiParam {Number} project_id 项目ID
|
||
*/
|
||
public function exit()
|
||
{
|
||
$user = User::auth();
|
||
//
|
||
$project_id = intval(Request::input('project_id'));
|
||
//
|
||
$project = Project::userProject($project_id);
|
||
if ($project->owner) {
|
||
return Base::retError('项目负责人无法退出项目');
|
||
}
|
||
//
|
||
AbstractModel::transaction(function() use ($user, $project) {
|
||
$row = ProjectUser::whereProjectId($project->id)->whereUserid($user->userid)->first();
|
||
$row && $row->exitProject();
|
||
$project->syncDialogUser();
|
||
$project->addLog("会员ID：" . $user->userid . " 退出项目");
|
||
$project->pushMsg('delete', null, $user->userid);
|
||
});
|
||
return Base::retSuccess('退出成功', ['id' => $project->id]);
|
||
}
|
||
|
||
/**
|
||
* 归档项目（限：项目负责人）
|
||
*
|
||
* @apiParam {Number} project_id 项目ID
|
||
* @apiParam {String} [type] 类型
|
||
* - add：归档（默认）
|
||
* - recovery：还原归档
|
||
*/
|
||
public function archived()
|
||
{
|
||
User::auth();
|
||
//
|
||
$project_id = intval(Request::input('project_id'));
|
||
$type = Request::input('type', 'add');
|
||
//
|
||
$project = Project::userProject($project_id, false);
|
||
if (!$project->owner) {
|
||
return Base::retError('仅限项目负责人操作');
|
||
}
|
||
//
|
||
if ($type == 'recovery') {
|
||
$project->archivedProject(null);
|
||
} elseif ($type == 'add') {
|
||
$project->archivedProject(Carbon::now());
|
||
}
|
||
return Base::retSuccess('设置成功', ['id' => $project->id]);
|
||
}
|
||
|
||
/**
|
||
* 删除项目（限：项目负责人）
|
||
*
|
||
* @apiParam {Number} project_id 项目ID
|
||
*/
|
||
public function remove()
|
||
{
|
||
User::auth();
|
||
//
|
||
$project_id = intval(Request::input('project_id'));
|
||
//
|
||
$project = Project::userProject($project_id);
|
||
if (!$project->owner) {
|
||
return Base::retError('仅限项目负责人删除');
|
||
}
|
||
//
|
||
$project->deleteProject();
|
||
return Base::retSuccess('删除成功', ['id' => $project->id]);
|
||
}
|
||
|
||
/**
|
||
* 获取任务列表
|
||
*
|
||
* @apiParam {Number} project_id 项目ID
|
||
*
|
||
* @apiParam {Number} [page] 当前页，默认:1
|
||
* @apiParam {Number} [pagesize] 每页显示数量，默认:100，最大:200
|
||
*/
|
||
public function column__lists()
|
||
{
|
||
User::auth();
|
||
//
|
||
$project_id = intval(Request::input('project_id'));
|
||
// 项目
|
||
$project = Project::userProject($project_id);
|
||
//
|
||
$list = ProjectColumn::whereProjectId($project->id)
|
||
->orderBy('sort')
|
||
->orderBy('id')
|
||
->paginate(Base::getPaginate(200, 100));
|
||
//
|
||
return Base::retSuccess('success', $list);
|
||
}
|
||
|
||
/**
|
||
* 添加任务列表
|
||
*
|
||
* @apiParam {Number} project_id 项目ID
|
||
* @apiParam {String} name 列表名称
|
||
*/
|
||
public function column__add()
|
||
{
|
||
User::auth();
|
||
//
|
||
$project_id = intval(Request::input('project_id'));
|
||
$name = trim(Request::input('name'));
|
||
// 项目
|
||
$project = Project::userProject($project_id);
|
||
//
|
||
if (empty($name)) {
|
||
return Base::retError('列表名称不能为空');
|
||
}
|
||
$column = ProjectColumn::createInstance([
|
||
'project_id' => $project->id,
|
||
'name' => $name,
|
||
]);
|
||
$column->sort = intval(ProjectColumn::whereProjectId($project->id)->orderByDesc('sort')->value('sort')) + 1;
|
||
$column->save();
|
||
$column->addLog("创建列表：" . $column->name);
|
||
//
|
||
$data = ProjectColumn::find($column->id);
|
||
$data->project_task = [];
|
||
$data->pushMsg("add", $data);
|
||
return Base::retSuccess('添加成功', $data);
|
||
}
|
||
|
||
/**
|
||
* 修改任务列表
|
||
*
|
||
* @apiParam {Number} column_id 列表ID
|
||
* @apiParam {String} [name] 列表名称
|
||
* @apiParam {String} [color] 颜色
|
||
*/
|
||
public function column__update()
|
||
{
|
||
User::auth();
|
||
//
|
||
$data = Request::all();
|
||
$column_id = intval($data['column_id']);
|
||
// 列表
|
||
$column = ProjectColumn::whereId($column_id)->first();
|
||
if (empty($column)) {
|
||
return Base::retError('列表不存在');
|
||
}
|
||
// 项目
|
||
Project::userProject($column->project_id);
|
||
//
|
||
if (Arr::exists($data, 'name') && $column->name != $data['name']) {
|
||
$column->addLog("修改列表名称：{$column->name} => {$data['name']}");
|
||
$column->name = $data['name'];
|
||
}
|
||
if (Arr::exists($data, 'color') && $column->color != $data['color']) {
|
||
$column->addLog("修改列表颜色：{$column->color} => {$data['color']}");
|
||
$column->color = $data['color'];
|
||
}
|
||
$column->save();
|
||
$column->pushMsg("update", $column);
|
||
return Base::retSuccess('修改成功', $column);
|
||
}
|
||
|
||
/**
|
||
* 删除任务列表
|
||
*
|
||
* @apiParam {Number} column_id 列表ID（留空为添加列表）
|
||
*/
|
||
public function column__remove()
|
||
{
|
||
User::auth();
|
||
//
|
||
$column_id = intval(Request::input('column_id'));
|
||
// 列表
|
||
$column = ProjectColumn::whereId($column_id)->first();
|
||
if (empty($column)) {
|
||
return Base::retError('列表不存在');
|
||
}
|
||
// 项目
|
||
Project::userProject($column->project_id);
|
||
//
|
||
$column->deleteColumn();
|
||
return Base::retSuccess('删除成功', ['id' => $column->id]);
|
||
}
|
||
|
||
/**
|
||
* 任务列表
|
||
*
|
||
* @apiParam {Number} [project_id] 项目ID
|
||
* @apiParam {Number} [parent_id] 主任务ID（填写此项时 project_id 参数无效）
|
||
* @apiParam {String} [name] 任务描述关键词
|
||
* @apiParam {Array} [time] 指定时间范围，如：['2020-12-12', '2020-12-30']
|
||
* @apiParam {String} [time_before] 指定时间之前，如：2020-12-30 00:00:00（填写此项时 time 参数无效）
|
||
* @apiParam {String} [complete] 完成状态
|
||
* - all：所有（默认）
|
||
* - yes：已完成
|
||
* - no：未完成
|
||
* @apiParam {String} [archived] 归档状态
|
||
* - yes：已归档
|
||
* - no：未归档（默认）
|
||
*/
|
||
public function task__lists()
|
||
{
|
||
User::auth();
|
||
//
|
||
$builder = ProjectTask::with(['taskUser', 'taskTag']);
|
||
//
|
||
$parent_id = intval(Request::input('parent_id'));
|
||
$project_id = intval(Request::input('project_id'));
|
||
$name = Request::input('name');
|
||
$time = Request::input('time');
|
||
$time_before = Request::input('time_before');
|
||
$complete = Request::input('complete', 'all');
|
||
$archived = Request::input('archived', 'no');
|
||
//
|
||
if ($parent_id > 0) {
|
||
ProjectTask::userTask($parent_id);
|
||
$builder->whereParentId($parent_id);
|
||
} elseif ($project_id > 0) {
|
||
Project::userProject($project_id);
|
||
$builder->whereParentId(0)->whereProjectId($project_id);
|
||
} else {
|
||
$builder->whereParentId(0)->authData();
|
||
}
|
||
//
|
||
if ($name) {
|
||
$builder->where(function($query) use ($name) {
|
||
$query->where("name", "like", "%{$name}%");
|
||
});
|
||
}
|
||
//
|
||
if (Base::isDateOrTime($time_before)) {
|
||
$builder->whereNotNull('end_at')->where('end_at', '<', Carbon::parse($time_before));
|
||
} elseif (is_array($time)) {
|
||
if (Base::isDateOrTime($time[0]) && Base::isDateOrTime($time[1])) {
|
||
$between = [
|
||
Carbon::parse($time[0])->startOfDay(),
|
||
Carbon::parse($time[1])->endOfDay()
|
||
];
|
||
$builder->where(function ($query) use ($between) {
|
||
$query->whereBetween('start_at', $between)->orWhereBetween('end_at', $between);
|
||
});
|
||
}
|
||
}
|
||
//
|
||
if ($complete === 'yes') {
|
||
$builder->whereNotNull('complete_at');
|
||
} elseif ($complete === 'no') {
|
||
$builder->whereNull('complete_at');
|
||
}
|
||
//
|
||
if ($archived == 'yes') {
|
||
$builder->whereNotNull('archived_at');
|
||
} elseif ($archived == 'no') {
|
||
$builder->whereNull('archived_at');
|
||
}
|
||
//
|
||
$list = $builder->orderByDesc('id')->paginate(Base::getPaginate(200, 100));
|
||
//
|
||
return Base::retSuccess('success', $list);
|
||
}
|
||
|
||
/**
|
||
* 获取单个任务信息
|
||
*
|
||
* @apiParam {Number} task_id 任务ID
|
||
*/
|
||
public function task__one()
|
||
{
|
||
User::auth();
|
||
//
|
||
$task_id = intval(Request::input('task_id'));
|
||
//
|
||
$task = ProjectTask::userTask($task_id, ['taskUser', 'taskTag'], true, $project);
|
||
//
|
||
$task->project_name = $project?->name;
|
||
$task->column_name = ProjectColumn::whereId($task->column_id)->value('name');
|
||
//
|
||
return Base::retSuccess('success', $task);
|
||
}
|
||
|
||
/**
|
||
* 获取任务详细描述
|
||
*
|
||
* @apiParam {Number} task_id 任务ID
|
||
*/
|
||
public function task__content()
|
||
{
|
||
User::auth();
|
||
//
|
||
$task_id = intval(Request::input('task_id'));
|
||
//
|
||
$task = ProjectTask::userTask($task_id);
|
||
//
|
||
return Base::retSuccess('success', $task->content ?: json_decode('{}'));
|
||
}
|
||
|
||
/**
|
||
* 获取任务文件列表
|
||
*
|
||
* @apiParam {Number} task_id 任务ID
|
||
*/
|
||
public function task__files()
|
||
{
|
||
User::auth();
|
||
//
|
||
$task_id = intval(Request::input('task_id'));
|
||
//
|
||
$task = ProjectTask::userTask($task_id);
|
||
//
|
||
return Base::retSuccess('success', $task->taskFile);
|
||
}
|
||
|
||
/**
|
||
* 删除任务文件（限：项目、任务负责人）
|
||
*
|
||
* @apiParam {Number} file_id 文件ID
|
||
*/
|
||
public function task__filedelete()
|
||
{
|
||
User::auth();
|
||
//
|
||
$file_id = intval(Request::input('file_id'));
|
||
//
|
||
$file = ProjectTaskFile::find($file_id);
|
||
if (empty($file)) {
|
||
return Base::retError('文件不存在或已被删除');
|
||
}
|
||
//
|
||
$task = ProjectTask::userTask($file->task_id, [], true, $project);
|
||
if (!$task->owner && !$project->owner) {
|
||
return Base::retError('仅限项目或任务负责人操作');
|
||
}
|
||
//
|
||
$task->pushMsg('filedelete', $file);
|
||
$file->delete();
|
||
//
|
||
return Base::retSuccess('success', $file);
|
||
}
|
||
|
||
/**
|
||
* {post} 添加任务
|
||
*
|
||
* @apiParam {Number} project_id 项目ID
|
||
* @apiParam {mixed} [column_id] 列表ID，任意值自动创建，留空取第一个
|
||
* @apiParam {String} name 任务描述
|
||
* @apiParam {String} [content] 任务详情
|
||
* @apiParam {Array} [times] 计划时间（格式：开始时间,结束时间；如：2020-01-01 00:00,2020-01-01 23:59）
|
||
* @apiParam {Number} [owner] 负责人
|
||
* @apiParam {Array} [subtasks] 子任务（格式：[{name,owner,times}]）
|
||
* @apiParam {Number} [top] 添加的任务排到列表最前面
|
||
*/
|
||
public function task__add()
|
||
{
|
||
User::auth();
|
||
parse_str(Request::getContent(), $data);
|
||
$project_id = intval($data['project_id']);
|
||
$column_id = $data['column_id'];
|
||
// 项目
|
||
$project = Project::userProject($project_id);
|
||
// 列表
|
||
$column = null;
|
||
$newColumn = null;
|
||
if ($column_id) {
|
||
if (intval($column_id) > 0) {
|
||
$column = $project->projectColumn->find($column_id);
|
||
}
|
||
if (empty($column)) {
|
||
$column = ProjectColumn::whereProjectId($project->id)->whereName($column_id)->first();
|
||
}
|
||
} else {
|
||
$column = ProjectColumn::whereProjectId($project->id)->orderBy('id')->first();
|
||
}
|
||
if (empty($column)) {
|
||
$column = ProjectColumn::createInstance([
|
||
'project_id' => $project->id,
|
||
'name' => $column_id ?: 'Default',
|
||
]);
|
||
$column->sort = intval(ProjectColumn::whereProjectId($project->id)->orderByDesc('sort')->value('sort')) + 1;
|
||
$column->save();
|
||
$column->addLog("创建列表：" . $column->name);
|
||
$newColumn = $column->find($column->id);
|
||
$newColumn->project_task = [];
|
||
}
|
||
if (empty($column)) {
|
||
return Base::retError('任务列表不存在或已被删除');
|
||
}
|
||
//
|
||
$task = ProjectTask::addTask(array_merge($data, [
|
||
'parent_id' => 0,
|
||
'project_id' => $project->id,
|
||
'column_id' => $column->id,
|
||
]));
|
||
$data = [
|
||
'new_column' => $newColumn,
|
||
'task' => ProjectTask::with(['taskUser', 'taskTag'])->find($task->id),
|
||
];
|
||
$task->pushMsg('add', $data);
|
||
return Base::retSuccess('添加成功', $data);
|
||
}
|
||
|
||
/**
|
||
* 添加子任务（限：项目、任务负责人）
|
||
*
|
||
* @apiParam {Number} task_id 任务ID
|
||
* @apiParam {String} name 任务描述
|
||
*/
|
||
public function task__addsub()
|
||
{
|
||
User::auth();
|
||
//
|
||
$task_id = intval(Request::input('task_id'));
|
||
$name = Request::input('name');
|
||
//
|
||
$task = ProjectTask::userTask($task_id, [], true, $project);
|
||
if (!$task->owner && !$project->owner) {
|
||
return Base::retError('仅限项目或任务负责人添加');
|
||
}
|
||
//
|
||
$task = ProjectTask::addTask([
|
||
'name' => $name,
|
||
'parent_id' => $task->id,
|
||
'project_id' => $task->project_id,
|
||
'column_id' => $task->column_id,
|
||
'owner' => [User::userid()]
|
||
]);
|
||
$data = [
|
||
'new_column' => null,
|
||
'task' => ProjectTask::with(['taskUser', 'taskTag'])->find($task->id),
|
||
];
|
||
$task->pushMsg('add', $data);
|
||
return Base::retSuccess('添加成功', $data);
|
||
}
|
||
|
||
/**
|
||
* {post} 修改任务、子任务（限：项目、任务负责人）
|
||
*
|
||
* @apiParam {Number} task_id 任务ID
|
||
* @apiParam {String} [name] 任务描述
|
||
* @apiParam {Array} [times] 计划时间（格式：开始时间,结束时间；如：2020-01-01 00:00,2020-01-01 23:59）
|
||
* @apiParam {Array} [owner] 修改负责人
|
||
* @apiParam {String} [content] 任务详情（子任务不支持）
|
||
* @apiParam {String} [color] 背景色（子任务不支持）
|
||
* @apiParam {Array} [assist] 修改协助人员（子任务不支持）
|
||
*
|
||
* @apiParam {Number} [p_level] 优先级相关（子任务不支持）
|
||
* @apiParam {String} [p_name] 优先级相关（子任务不支持）
|
||
* @apiParam {String} [p_color] 优先级相关（子任务不支持）
|
||
*
|
||
* @apiParam {String|false} [complete_at] 完成时间（如：2020-01-01 00:00，false表示未完成）
|
||
*/
|
||
public function task__update()
|
||
{
|
||
User::auth();
|
||
//
|
||
parse_str(Request::getContent(), $data);
|
||
$task_id = intval($data['task_id']);
|
||
//
|
||
$task = ProjectTask::userTask($task_id, [], true, $project);
|
||
if (!$task->owner && !$project->owner) {
|
||
return Base::retError('仅限项目或任务负责人修改');
|
||
}
|
||
//
|
||
$updateComplete = false;
|
||
$updateContent = false;
|
||
if (Base::isDate($data['complete_at'])) {
|
||
// 标记已完成
|
||
if ($task->complete_at) {
|
||
return Base::retError('任务已完成');
|
||
}
|
||
$task->completeTask(Carbon::now());
|
||
$updateComplete = true;
|
||
} elseif (Arr::exists($data, 'complete_at')) {
|
||
// 标记未完成
|
||
if (!$task->complete_at) {
|
||
return Base::retError('未完成任务');
|
||
}
|
||
$task->completeTask(null);
|
||
$updateComplete = true;
|
||
} else {
|
||
// 更新任务
|
||
$task->updateTask($data, $updateContent);
|
||
}
|
||
$data = ProjectTask::with(['taskUser', 'taskTag'])->find($task->id);
|
||
$data->is_update_complete = $task->parent_id == 0 && $updateComplete;
|
||
$data->is_update_content = $updateContent;
|
||
$task->pushMsg('update', $data);
|
||
return Base::retSuccess('修改成功', $data);
|
||
}
|
||
|
||
/**
|
||
* {post} 上传文件（限：项目、任务负责人）
|
||
*
|
||
* @apiParam {Number} task_id 任务ID
|
||
* @apiParam {String} [filename] post-文件名称
|
||
* @apiParam {String} [image64] post-base64图片（二选一）
|
||
* @apiParam {File} [files] post-文件对象（二选一）
|
||
*/
|
||
public function task__upload()
|
||
{
|
||
$user = User::auth();
|
||
//
|
||
$task_id = Base::getPostInt('task_id');
|
||
//
|
||
$task = ProjectTask::userTask($task_id, [], true, $project);
|
||
if (!$task->owner && !$project->owner) {
|
||
return Base::retError('仅限项目或任务负责人上传');
|
||
}
|
||
//
|
||
$path = "uploads/task/" . $task->id . "/";
|
||
$image64 = Base::getPostValue('image64');
|
||
$fileName = Base::getPostValue('filename');
|
||
if ($image64) {
|
||
$data = Base::image64save([
|
||
"image64" => $image64,
|
||
"path" => $path,
|
||
"fileName" => $fileName,
|
||
]);
|
||
} else {
|
||
$data = Base::upload([
|
||
"file" => Request::file('files'),
|
||
"type" => 'file',
|
||
"path" => $path,
|
||
"fileName" => $fileName,
|
||
]);
|
||
}
|
||
//
|
||
if (Base::isError($data)) {
|
||
return Base::retError($data['msg']);
|
||
} else {
|
||
$fileData = $data['data'];
|
||
$file = ProjectTaskFile::createInstance([
|
||
'project_id' => $task->project_id,
|
||
'task_id' => $task->id,
|
||
'name' => $fileData['name'],
|
||
'size' => $fileData['size'] * 1024,
|
||
'ext' => $fileData['ext'],
|
||
'path' => $fileData['path'],
|
||
'thumb' => Base::unFillUrl($fileData['thumb']),
|
||
'userid' => $user->userid,
|
||
]);
|
||
$file->save();
|
||
//
|
||
$file = ProjectTaskFile::find($file->id);
|
||
$task->addLog("上传文件：" . $file->name);
|
||
$task->pushMsg('upload', $file);
|
||
return Base::retSuccess("上传成功", $file);
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 创建/获取聊天室
|
||
*
|
||
* @apiParam {Number} task_id 任务ID
|
||
*/
|
||
public function task__dialog()
|
||
{
|
||
User::auth();
|
||
//
|
||
$task_id = intval(Request::input('task_id'));
|
||
//
|
||
$task = ProjectTask::userTask($task_id);
|
||
//
|
||
if ($task->parent_id > 0) {
|
||
return Base::retError('子任务不支持此功能');
|
||
}
|
||
//
|
||
AbstractModel::transaction(function() use ($task) {
|
||
if (empty($task->dialog_id)) {
|
||
$task->lockForUpdate();
|
||
$dialog = WebSocketDialog::createGroup(null, $task->relationUserids(), 'task');
|
||
if ($dialog) {
|
||
$task->dialog_id = $dialog->id;
|
||
$task->save();
|
||
}
|
||
}
|
||
if (empty($task->dialog_id)) {
|
||
throw new ApiException('创建聊天失败');
|
||
}
|
||
});
|
||
//
|
||
$task->pushMsg('dialog');
|
||
return Base::retSuccess('success', [
|
||
'id' => $task->id,
|
||
'dialog_id' => $task->dialog_id,
|
||
]);
|
||
}
|
||
|
||
/**
|
||
* 归档任务（限：项目、任务负责人）
|
||
*
|
||
* @apiParam {Number} task_id 任务ID
|
||
* @apiParam {String} [type] 类型
|
||
* - add：归档（默认）
|
||
* - recovery：还原归档
|
||
*/
|
||
public function task__archived()
|
||
{
|
||
User::auth();
|
||
//
|
||
$task_id = intval(Request::input('task_id'));
|
||
$type = Request::input('type', 'add');
|
||
//
|
||
$task = ProjectTask::userTask($task_id, [], false, $project);
|
||
if (!$task->owner && !$project->owner) {
|
||
return Base::retError('仅限项目或任务负责人操作');
|
||
}
|
||
//
|
||
if ($task->parent_id > 0) {
|
||
return Base::retError('子任务不支持此功能');
|
||
}
|
||
//
|
||
if ($type == 'recovery') {
|
||
$task->archivedTask(null);
|
||
} elseif ($type == 'add') {
|
||
$task->archivedTask(Carbon::now());
|
||
}
|
||
return Base::retSuccess('设置成功', ['id' => $task->id]);
|
||
}
|
||
|
||
/**
|
||
* 删除任务（限：项目、任务负责人）
|
||
*
|
||
* @apiParam {Number} task_id 任务ID
|
||
*/
|
||
public function task__remove()
|
||
{
|
||
User::auth();
|
||
//
|
||
$task_id = intval(Request::input('task_id'));
|
||
//
|
||
$task = ProjectTask::userTask($task_id, [], true, $project);
|
||
if (!$task->owner && !$project->owner) {
|
||
return Base::retError('仅限项目或任务负责人删除');
|
||
}
|
||
//
|
||
$task->deleteTask();
|
||
return Base::retSuccess('删除成功', ['id' => $task->id]);
|
||
}
|
||
|
||
/**
|
||
* 获取项目、任务日志
|
||
*
|
||
* @apiParam {Number} project_id 项目ID
|
||
* @apiParam {Number} task_id 任务ID（与 项目ID 二选一，任务ID优先）
|
||
*
|
||
* @apiParam {Number} [page] 当前页，默认:1
|
||
* @apiParam {Number} [pagesize] 每页显示数量，默认:20，最大:100
|
||
*/
|
||
public function log__lists()
|
||
{
|
||
User::auth();
|
||
//
|
||
$project_id = intval(Request::input('project_id'));
|
||
$task_id = intval(Request::input('task_id'));
|
||
//
|
||
$builder = ProjectLog::with(['user']);
|
||
if ($task_id > 0) {
|
||
$task = ProjectTask::userTask($task_id);
|
||
$builder->whereTaskId($task->id);
|
||
} else {
|
||
$project = Project::userProject($project_id);
|
||
$builder->whereProjectId($project->id);
|
||
}
|
||
//
|
||
$list = $builder->orderByDesc('created_at')->paginate(Base::getPaginate(100, 20));
|
||
$list->transform(function (ProjectLog $log) {
|
||
$timestamp = Carbon::parse($log->created_at)->timestamp;
|
||
$log->time = [
|
||
'ymd' => date(date("Y", $timestamp) == date("Y", Base::time()) ? "m-d" : "Y-m-d", $timestamp),
|
||
'hi' => date("h:i", $timestamp) ,
|
||
'week' => "周" . Base::getTimeWeek($timestamp),
|
||
'segment' => Base::getTimeDayeSegment($timestamp),
|
||
];
|
||
return $log;
|
||
});
|
||
//
|
||
return Base::retSuccess('success', $list);
|
||
}
|
||
}
|