<?php
namespace app\common\Model;
use service\FileService;
use think\Db;
use think\facade\Hook;
use think\File as thinkFile;
/**
* 项目
* Class Organization
* @package app\common\Model
*/
class Project extends CommonModel
{
protected $append = [];
protected $defaultStages = [['name' => '待处理'], ['name' => '进行中'], ['name' => '已完成']];
public static function getEffectInfo($id)
{
return self::where(['id' => $id, 'deleted' => 0, 'archive' => 0])->find();
}
public function getMemberProjects($memberCode = '',$organizationCode = '', $deleted = 0, $archive = 0, $collection = -1, $page = 1, $pageSize = 10)
{
if (!$memberCode) {
$memberCode = getCurrentMember()['code'];
}
if (!$organizationCode) {
$organizationCode = getCurrentOrganizationCode();
}
if ($page < 1) {
$page = 1;
}
$offset = ($page - 1) * $pageSize;
$limit = $pageSize;
$prefix = config('database.prefix');
// and p.organization_code = '$organizationCode'
$sql = "select *,p.id as id,p.name as name,p.code as code,p.create_time as create_time from {$prefix}project as p join {$prefix}project_member as pm on p.code = pm.project_code left join {$prefix}project_collection as pc on p.code = pc.project_code where pm.member_code = '{$memberCode}' ";
if ($deleted != -1) {
$sql .= " and p.deleted = {$deleted} ";
}
if ($archive != -1) {
$sql .= " and p.archive = {$archive} ";
}
if ($collection == 1) {
$sql .= " and pc.project_code is not null and pc.member_code = '{$memberCode}'";
}
$sql .= "group by p.id order by pc.id desc, p.id desc";
$total = Db::query($sql);
$total = count($total);
$sql .= " limit {$offset},{$limit}";
$list = Db::query($sql);
return ['list' => $list, 'total' => $total];
}
/**
* 创建项目
* @param $memberCode
* @param $orgCode
* @param $name
* @param string $description
* @param string $templateCode
* @return Project
* @throws \Exception
*/
public function createProject($memberCode, $orgCode, $name, $description = '', $templateCode = '')
{
//d85f1bvwpml2nhxe94zu7tyi
Db::startTrans();
try {
$project = [
'create_time' => nowTime(),
'code' => createUniqueCode('project'),
'name' => $name,
'description' => $description,
'organization_code' => $orgCode,
'task_board_theme' => 'simple',
'cover' => FileService::getFilePrefix() . 'static/image/default/project-cover.png'
];
$result = self::create($project);
$projectMemberModel = new ProjectMember();
$projectMemberModel->inviteMember($memberCode, $project['code'], 1);
if ($templateCode) {
$stages = TaskStagesTemplate::where(['project_template_code' => $templateCode])->order('sort desc,id asc')->select();
} else {
$stages = $this->defaultStages;
}
if ($stages) {
foreach ($stages as $key => $stage) {
$taskStage = [
'project_code' => $project['code'],
'name' => $stage['name'],
'sort' => $key,
'code' => createUniqueCode('taskStages'),
'create_time' => nowTime(),
];
$stagesResult = TaskStages::create($taskStage);
$taskStage['id'] = $stagesResult['id'];
}
}
Db::commit();
} catch (\Exception $e) {
Db::rollback();
throw new \Exception($e->getMessage(), 1);
}
self::projectHook(getCurrentMember()['code'], $project['code'], 'create');
return $result;
}
public function edit($code, $data)
{
if (!$code) {
throw new \Exception('请选择项目', 1);
}
$project = self::where(['code' => $code, 'deleted' => 0])->field('id', true)->find();
if (!$project) {
throw new \Exception('该项目在回收站中无法编辑', 1);
}
$result = self::update($data, ['code' => $code]);
//TODO 项目动态
self::projectHook(getCurrentMember()['code'], $code, 'edit');
return $result;
}
/**
* @param File $file
* @return array|bool
* @throws \think\Exception
* @throws \think\exception\PDOException
* @throws \Exception
*/
public function uploadCover(thinkFile $file)
{
return $this->_uploadImg($file);
}
/**
* 放入回收站
* @param $code
* @return Project
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\ModelNotFoundException
* @throws \think\exception\DbException
*/
public function recycle($code)
{
$info = self::where(['code' => $code])->find();
if (!$info) {
throw new \Exception('项目不存在', 1);
}
if ($info['deleted']) {
throw new \Exception('项目已在回收站', 2);
}
$result = self::update(['deleted' => 1, 'deleted_time' => nowTime()], ['code' => $code]);
self::projectHook(getCurrentMember()['code'], $code, 'recycle');
return $result;
}
/**
* 恢复项目
* @param $code
* @return Project
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\ModelNotFoundException
* @throws \think\exception\DbException
*/
public function recovery($code)
{
$info = self::where(['code' => $code])->find();
if (!$info) {
throw new \Exception('项目不存在', 1);
}
if (!$info['deleted']) {
throw new \Exception('项目已恢复', 2);
}
$result = self::update(['deleted' => 0], ['code' => $code]);
self::projectHook(getCurrentMember()['code'], $code, 'recovery');
return $result;
}
/**
* 项目归档
* @param $code
* @return Project
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\ModelNotFoundException
* @throws \think\exception\DbException
*/
public function archive($code)
{
$info = self::where(['code' => $code])->find();
if (!$info) {
throw new \Exception('项目不存在', 1);
}
if ($info['archive']) {
throw new \Exception('项目已归档', 2);
}
$result = self::update(['archive' => 1, 'archive_time' => nowTime()], ['code' => $code]);
self::projectHook(getCurrentMember()['code'], $code, 'archive');
return $result;
}
/**
* 恢复项目
* @param $code
* @return Project
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\ModelNotFoundException
* @throws \think\exception\DbException
*/
public function recoveryArchive($code)
{
$info = self::where(['code' => $code])->find();
if (!$info) {
throw new \Exception('项目不存在', 1);
}
if (!$info['archive']) {
throw new \Exception('项目已恢复', 2);
}
$result = self::update(['archive' => 0], ['code' => $code]);
self::projectHook(getCurrentMember()['code'], $code, 'recoveryArchive');
return $result;
}
/**
* 退出项目
* @param $code
* @return bool
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\ModelNotFoundException
* @throws \think\exception\DbException
* @throws \Exception
*/
public function quit($code)
{
$info = self::where(['code' => $code])->find();
if (!$info) {
throw new \Exception('项目不存在', 1);
}
$where = ['project_code' => $code, 'member_code' => getCurrentMember()['code']];
$projectMember = ProjectMember::where($where)->find();
if (!$projectMember) {
throw new \Exception('你不是该项目成员', 2);
}
if ($projectMember['is_owner']) {
throw new \Exception('创建者不能退出项目', 3);
}
$result = ProjectMember::where($where)->delete();
return $result;
}
/** 项目变动钩子
* @param $memberCode
* @param $sourceCode
* @param string $type
* @param string $toMemberCode
* @param int $isComment
* @param string $remark
* @param string $content
* @param string $fileCode
* @param array $data
* @param string $tag
*/
public static function projectHook($memberCode, $sourceCode, $type = 'create', $toMemberCode = '', $isComment = 0, $remark = '', $content = '', $fileCode = '', $data = [], $tag = 'project')
{
$data = ['memberCode' => $memberCode, 'sourceCode' => $sourceCode, 'remark' => $remark, 'type' => $type, 'content' => $content, 'isComment' => $isComment, 'toMemberCode' => $toMemberCode, 'fileCode' => $fileCode, 'data' => $data, 'tag' => $tag];
Hook::listen($tag, $data);
}
}