<?php
// +----------------------------------------------------------------------
// | Description: 项目管理
// +----------------------------------------------------------------------
// | Author: Michael_xu | gengxiaoxu@5kcrm.com
// +----------------------------------------------------------------------
namespace app\work\model;
use app\admin\controller\ApiCommon;
use think\Db;
use app\admin\model\Common;
class Work extends Common
{
/**
* 为了数据库的整洁，同时又不影响Model和Controller的名称
* 我们约定每个模块的数据表都加上相同的前缀，比如微信模块用weixin作为数据表前缀
*/
protected $name = 'work';
protected $createTime = 'create_time';
protected $updateTime = 'update_time';
protected $autoWriteTimestamp = true;
protected $insert = ['status' => 1];
/**
* 列表
*
* @return bool|\PDOStatement|string|\think\Collection
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\ModelNotFoundException
* @throws \think\exception\DbException
*/
public function getDataList()
{
$list = $this->where(['status' => 1])->field('work_id,name,status,create_time')->select();
return $list ;
}
/**
* 创建项目
*
* @param array $param
* @return array|bool|float|int|mixed|object|\stdClass|null
* @throws \think\exception\PDOException
*/
public function createData($param)
{
$this->startTrans();
try {
# 设置项目参数
if (!empty($param['is_open']) && $param['is_open'] == 1) {
$ownerUserId = Db::name('admin_user')->where('status', 1)->column('id');
} else {
$ownerUserId = $param['owner_user_id'] ? : [];
}
$param['owner_user_id'] = $ownerUserId ? arrayToString($ownerUserId) : '';
$param['status'] = 1;
# 创建项目
$this->data($param)->allowField(true)->save();
# 设置项目下的任务参数
$workId = $this->work_id;
$createTime = time();
$createUserId = $param['create_user_id'];
$taskData = [
['name' => '要做', 'create_time' => $createTime, 'create_user_id' => $createUserId, 'status' => 1, 'work_id' => $workId, 'order_id' => 1],
['name' => '在做', 'create_time' => $createTime, 'create_user_id' => $createUserId, 'status' => 1, 'work_id' => $workId, 'order_id' => 2],
['name' => '待定', 'create_time' => $createTime, 'create_user_id' => $createUserId, 'status' => 1, 'work_id' => $workId, 'order_id' => 3]
];
# 创建项目下的任务
Db::name('work_task_class')->insertAll($taskData);
# 设置项目下的相关成员参数
$ownerData['work_id'] = $workId;
$ownerData['create_user_id'] = $createUserId;
$ownerData['owner_user_id'] = $ownerUserId;
$group= Db::name('admin_group')->field(['id', 'title', 'rules', 'remark', 'system'])->where(['pid' => 5, 'types' => 7, 'status' => 1])->order('id','asc')->select();
$ownerData['group_id'] = !empty($param['group_id']) ? $param['group_id'] : $group[0]['id'];
# 创建项目下的相关成员
$this->addOwner($ownerData);
# 提交事务
$this->commit();
$user=new ApiCommon();
$userInfo=$user->userInfo;
RecordActionLog($param['create_user_id'], 'work', 'save',$param['name'], '','','添加了项目：'.$param['name']);
return $workId;
} catch(\Exception $e) {
# 回滚事务
$this->rollback();
# 错误原因
$this->error = '添加失败';
return false;
}
}
/**
* 更新项目排序表
*
* @param int $workId 项目ID
* @param int $userId 用户ID
* @author fanqi
* @since 2021-03-27
*/
public function updateWorkOrder($workId, $userId)
{
$workOrder = 0;
$workOrderList = db('work_order')->where('user_id', $userId)->select();
foreach ($workOrderList AS $key => $value) {
if (!empty($value['order']) && $value > $workOrder) $workOrder = $value['order'];
}
# 只同步有排序操作的用户的数据
if (!empty($workOrder)) db('work_order')->insert([
'work_id' => $workId,
'user_id' => $userId,
'order' => $workOrder + 1
]);
}
/**
* 编辑项目
*
* @param $param
* @return bool
* @throws \think\Exception
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\ModelNotFoundException
* @throws \think\exception\DbException
* @throws \think\exception\PDOException
*/
public function updateDataById($param)
{
$param['update_time'] = time();
$userId = $param['user_id'];
unset($param['user_id']);
$map['work_id'] = $param['work_id'];
$workInfo = $this->where(['work_id' => $param['work_id']])->find();
# 公有改私有
if (isset($param['is_open']) && empty($param['is_open']) && $workInfo['is_open'] == 1) {
$ownerData = [];
$ownerData['work_id'] = $param['work_id'];
$ownerData['create_user_id'] = $workInfo['create_user_id'];
$ownerData['owner_user_id'] = !empty($param['owner_user_id']) ? stringToArray($param['owner_user_id']) : stringToArray($workInfo['create_user_id']);
$ownerData['is_open'] = $param['is_open'];
$ownerData['group_id'] = 0;
$this->addOwner($ownerData);
}
# 私有改公有
if (isset($param['is_open']) && !empty($param['is_open']) && $workInfo['is_open'] == 0) {
$ownerUserId = Db::name('admin_user')->where('status', 1)->column('id');
$ownerData['work_id'] = $param['work_id'];
$ownerData['create_user_id'] = $workInfo['create_user_id'];
$ownerData['owner_user_id'] = $ownerUserId;
$ownerData['is_open'] = $param['is_open'];
$ownerData['group_id'] = $param['group_id'];
$this->addOwner($ownerData);
}
# 公开项目更新时的权限变更
if ($param['is_open'] == 1 && !empty($param['group_id']) && $param['group_id'] != $workInfo['group_id']) {
db('work_user')->where(['work_id' => $workInfo['work_id'], 'user_id' => ['neq', $workInfo['create_user_id']]])->update(['group_id' => $param['group_id']]);
}
$resUpdata = $this->where($map)->update($param);
if ($resUpdata) {
$logmodel = model('WorkLog');
$datalog['type'] = 2; //重命名项目
$datalog['name'] = $param['name']; //项目名
$datalog['create_user_id'] = $userId;
$datalog['work_id'] = $param['work_id'];
$datalog['user_id'] = $userId;
$ret = $logmodel->workLogAdd($datalog);
RecordActionLog($userId, 'work', 'update',$param['name'], '','','编辑了项目：'.$param['name']);
return true;
} else {
$this->error = '重命名失败';
return false;
}
}
/**
* 删除项目
* @author yykun
* @param
* @return
*/
public function delWorkById($param)
{
$map['work_id'] = $param['work_id'];
Db::name('Task')->where($map)->delete();
Db::name('WorkTaskClass')->where($map)->delete();
$flag = $this->where($map)->delete();
if ($flag) {
$logmodel = new \app\work\model\WorkLog();
$datalog['status'] = 4; //删除项目
$datalog['create_user_id'] = $param['create_user_id'];
$datalog['work_id'] = $param['work_id'];
$datalog['content'] = '删除了项目';
$ret = $logmodel->workLogAdd($datalog);
return true;
} else {
$this->error = '数据不存在或已被删除';
return false;
}
}
/**
* 归档项目
* @author yykun
* @param
* @return
*/
public function archiveData($param)
{
$map['work_id'] = $param['work_id'];
$dataInfo=$this->get($param['work_id']);
$dataInfo = json_decode(json_encode($dataInfo), true);
$flag = $this->where($map)->setField('status',0);
$this->where($map)->setField('archive_time',time());
if ($flag) {
$data = [];
$data['status'] = 3;
$data['archive_time'] = time();
Db::name('task')->where($map)->update($data);
RecordActionLog($param['create_user_id'], 'work', 'archiveData',$dataInfo['name'], '','','归档了项目：'.$dataInfo['name']);
return true;
} else {
$this->error = '归档失败';
return false;
}
}
/**
* 归档项目列表
* @author yykun
* @param
* @return
*/
public function archiveList($param)
{
$page = !empty($param['page']) ? $param['page'] : 1;
$limit = !empty($param['limit']) ? $param['limit'] : 15;
unset($param['page']);
unset($param['limit']);
//权限
$map = $this->getWorkWhere($param);
$where['status'] = 0;
$where['ishidden'] = 0;
$count = $this->where($map)->where($where)->field('work_id,name,color,archive_time')->count();
$list = $this->where($map)->where($where)->field('work_id,name,color,archive_time')
->limit(($page - 1) * $limit, $limit)->select();
foreach ($list AS $key => $value) {
$list[$key]['archive_time'] = !empty($value['archive_time']) ? date('Y-m-d H:i:s', $value['archive_time']) : null;
}
return ['count' => $count, 'list' => $list];
}
/**
* 归档恢复
* @author yykun
* @param
* @return
*/
public function arRecover($work_id='',$userId)
{
if (!$work_id) {
$this->error = '参数错误';
return false;
}
$dataInfo=$this->get($work_id);
$dataInfo = json_decode(json_encode($dataInfo), true);
$map['work_id'] =$work_id;
$map['status'] = 0;
$this->where($map)->setField('status',1);
$map['status'] = 3;
Db::name('Task')->where($map)->setField('status',1);
RecordActionLog($userId, 'work', 'recover',$dataInfo['name'], '','','归档恢复项目：'.$dataInfo['name']);
return true;
}
/**
* 退出项目
* @author yykun
* @param 项目id,会员ID
* @return
*/
public function leaveById($work_id,$user_id)
{
$workInfo = $this->where(['work_id' => $work_id])->find();
if ($user_id == $workInfo['create_user_id']) {
$this->error = '项目创建人不可以退出';
return false;
}
//从项目成员中移除
db('work_user')->where(['work_id' => $work_id,'user_id' => $user_id])->delete();
$str = ','.$user_id.',';
if (in_array($user_id,stringToArray($workInfo['owner_user_id']))) {
$owner_user_id = str_replace($str,',',$workInfo['owner_user_id']);
$this->where(['work_id' => $work_id])->update(['owner_user_id' => $owner_user_id]);
}
$list = Db::name('Task')->where(['work_id' => $work_id])->select();
foreach ($list as $key => $value) {
$data = [];
if (in_array($user_id,stringToArray($value['owner_user_id']))) {
$new_own_user_id = str_replace($str,',',$value['owner_user_id']);
$data['owner_user_id'] = $new_own_user_id;
}
if ($value['main_user_id'] == $workInfo['create_user_id']) {
$data['main_user_id'] = '';
}
if ($data) Db::name('Task')->where(['task_id' => $value['task_id']])->update($data);
RecordActionLog($user_id, 'work_task', 'recover',$value['name'], '','','退出了项目：'.$value['name']);
}
RecordActionLog($user_id, 'work', 'update',$workInfo['name'], '','','退出了项目：'.$workInfo['name']);
return true;
}
/**
* 添加项目成员
*
* @param $param
* @return bool
* @throws \think\Exception
* @throws \think\exception\DbException
* @throws \think\exception\PDOException
*/
public function addOwner($param)
{
$workInfo = $this->get($param['work_id']);
$oldOwner = stringToArray($workInfo['owner_user_id']);
$owner_user = $newOwner = $param['owner_user_id'];
# 更新项目表中的项目成员
$this->where(['work_id' => $param['work_id']])->update(['owner_user_id' => arrayToString($newOwner)]);
# 差集，需删除的
$del_user_ids = array_diff($oldOwner, $newOwner);
$create_user_id = !empty($param['create_user_id']) ? $param['create_user_id'] : '';
unset($param['create_user_id']);
$owner_user_arr = db('work_user')->where(['work_id' => $param['work_id']])->column('user_id');
foreach ($owner_user as $k=>$v) {
$data = [];
if (in_array($v,$owner_user_arr)) continue;
$data['work_id'] = $param['work_id'];
$data['user_id'] = $v;
$data['types'] = 0;
if ($v == $create_user_id) {
$data['types'] = 1;
$group_id = $param['group_id'];
} else {
# 默认角色
$group_id = !empty($param['group_id']) ? $param['group_id'] : db('admin_group')->where(['pid' => 5, 'system' => 1])->order('id asc')->value('id');
}
$data['group_id'] = $group_id;
$saveData[] = $data;
}
$res = true;
if ($saveData && !db('work_user')->insertAll($saveData)) {
$res = false;
}
if ($del_user_ids && !db('work_user')->where(['work_id' => $param['work_id'],'user_id' => ['in',$del_user_ids]])->delete()) {
$res = false;
}
return $res;
}
/**
* 删除项目成员
* @author yykun
* @param
* @return
*/
public function delOwner($param,$userId)
{
$work_id = $param['work_id'];
$workUserInfo = db('work_user')->where(['work_id' => $work_id,'user_id' => $param['owner_user_id']])->find();
if (!$workUserInfo) {
$this->error = '数据不存在或已删除';
return false;
}
if ($workUserInfo['types'] == 1) {
$this->error = '项目负责人不能删除';
return false;
}
$res = db('work_user')->where(['id' => $workUserInfo['id']])->delete();
$owner_user_id[] = $param['owner_user_id'];
$workInfo = $this->get($param['work_id']);
$oldOwner = stringToArray($workInfo['owner_user_id']);
$newOwner = array_diff($oldOwner,$owner_user_id);
$resUpdate = $this->where(['work_id' => $work_id])->update(['owner_user_id' => arrayToString($newOwner)]);
if (!$res || !$resUpdate){
$this->error = '删除失败，请重试！';
return false;
}
$user= new \app\admin\model\User();
$user_info=$user->getUserById($param['owner_user_id']);
RecordActionLog($userId, 'work', 'save',$workInfo['name'], '','','删除了项目成员：'.$user_info['realname']);
return true;
}
/**
* 项目成员列表
* @author yykun
* @param
* @return
*/
public function ownerList($param)
{
if ($param['work_id']) {
$workInfo = $this->get($param['work_id']);
if ($workInfo['is_open'] == 1) {
//公开项目
// $list = db('admin_user')->where(['status' => 1])->field('username,realname,thumb_img,id')->select();
$list = db('work_user')
->alias('work')
->join('__ADMIN_USER__ user', 'user.id = work.user_id', 'LEFT')
->where(['work.work_id' => $param['work_id']])
->field('work.*,user.username,user.realname,user.thumb_img')
->order('work.types desc,user.id asc')
->select();
} else {
// $exp = new \think\db\Expression('field(types,1,0,2)');
$list = db('work_user')
->alias('work')
->join('__ADMIN_USER__ user', 'user.id = work.user_id', 'LEFT')
->where(['work.work_id' => $param['work_id']])
->field('work.*,user.username,user.realname,user.thumb_img')
->order('work.types desc,user.id asc')
->select();
}
} else {
$list = db('admin_user')->where(['status' => 1])->field('username,realname,thumb_img,id')->select();
}
if ($list) {
foreach ($list as $k=>$v) {
$list[$k]['thumb_img'] = $v['thumb_img'] ? getFullPath($v['thumb_img']) : '';
$list[$k]['id'] = $v['user_id'] ? : $v['id'];
}
}
return $list ? : [];
}
/**
* 项目权限判断(成员)
* @author yykun
* @param
* @return
*/
public function checkWork($work_id, $user_id)
{
$info = $this->get($work_id);
if (!$info) {
$this->error = '该项目不存在或已删除';
return false;
}
//私有项目（成员可见）
$map = function($query) use ($user_id){
$query->whereOr(function ($query) use ($user_id) {
$query->where(['is_open' => 0,'owner_user_id' => array('like','%,'.$user_id.',%')]);
})
->whereOr(function ($query) use ($user_id) {
$query->where(['is_open' => 1]);
})
->whereOr(function ($query) use ($user_id) {
$query->where(['create_user_id' => $user_id]);
});
};
$resData = db('work')->where(['work_id' => $work_id])->where($map)->find();
$userMap = function($query) {
$query->where(['types' => 1])
->whereOr(['group_id' => 1]);
};
$adminUser = db('work_user')->where(['work_id' => $work_id])->where($userMap)->column('user_id');
$adminTypes = adminGroupTypes($user_id);
if (!$resData && !in_array(1,$adminTypes) && !in_array(7,$adminTypes) && !in_array($user_id,$adminUser)) {
$this->error = '没有权限';
return false;
}
return true;
}
/**
* 判断项目操作权限
*
* @param $m
* @param $c
* @param $a
* @param $work_id
* @param $user_id
* @return bool
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\ModelNotFoundException
* @throws \think\exception\DbException
*/
public function isCheck($m, $c, $a, $work_id, $user_id)
{
if (!$work_id) return false;
$adminTypes = adminGroupTypes($user_id);
$workInfo = Db::name('Work')->where(['work_id' => $work_id])->find();
if (in_array(1,$adminTypes) || in_array(7,$adminTypes)) {
return true;
}
//创建人有管理权限
if ($workInfo['create_user_id'] == $user_id) {
return true;
}
if (empty($workInfo['is_open'])) {
//私有项目
$groupInfo = db('work_user')->where(['work_id' => $work_id,'user_id' => $user_id])->find();
if ($groupInfo['types'] == 1 && $groupInfo['group_id'] == 1) {
return true;
}
$checkParam = [];
$checkParam['user_id'] = $user_id;
$checkParam['group_id'] = $groupInfo['group_id'];
if (checkWorkPerByAction($m, $c, $a, $checkParam)) {
return true;
}
} else {
if ($m == 'work' && $c == 'work' && $a == 'update') {
return false;
}
return true;
}
return false;
}
/**
* 获取项目权限范围
* @author Michael_xu
* @return
*/
public function getWorkWhere($param)
{
$user_id = $param['user_id'];
$adminTypes = adminGroupTypes($user_id);
$map = [];
if (!in_array(1,$adminTypes) && !in_array(7,$adminTypes)) {
$map = function($query) use ($user_id){
$query->whereOr(function ($query) use ($user_id) {
$query->where(['is_open' => 0,'owner_user_id' => array('like','%,'.$user_id.',%')]);
})
->whereOr(function ($query) use ($user_id) {
$query->where(['is_open' => 1]);
})
->whereOr(function ($query) use ($user_id) {
$query->where(['create_user_id' => $user_id]);
});
};
}
return $map ? : [];
}
/**
* 获取项目下权限信息
* @author Michael_xu
* @return
*/
public function authList($param)
{
$user_id = $param['user_id'];
$work_id = $param['work_id'];
$ruleMap = [];
$adminTypes = adminGroupTypes($user_id);
$ruleMap['types'] = ['eq',3];
$ruleMap['status'] = 1;
if (!in_array(1,$adminTypes) && !in_array(7,$adminTypes)) {
$workInfo = $this->get($work_id);
if ($workInfo['is_open'] == 1) {
//公开项目
if ($workInfo['create_user_id'] !== $user_id) {
$ruleMap['name'] = ['not in',['update']];
}
} else {
//私有项目
$groupInfo = db('work_user')->where(['work_id' => $work_id,'user_id' => $user_id])->find();
if ($groupInfo['types'] !== 1 || $groupInfo['group_id'] !== 1) {
$rule_ids = db('admin_group')->where(['id' => $groupInfo['group_id']])->value('rules');
$ruleIds = stringToArray($rule_ids);
if ($ruleIds) {
$ruleMap['id'] = array('in', $ruleIds);
} else {
$ruleMap['id'] = ['eq',3];
}
}
}
}
$newRuleIds = [];
// 重新设置ruleIds，除去部分已删除或禁用的权限。
$rules = Db::name('admin_rule')->where($ruleMap)->order('types asc')->select();
foreach ($rules as $k => $v) {
$newRuleIds[] = $v['id'];
$rules[$k]['name'] = strtolower($v['name']);
}
$tree = new \com\Tree();
$rulesList = $tree->list_to_tree($rules, 'id', 'pid', 'child', 0, true, array('pid'));
//权限数组
$authList = rulesListToArray($rulesList, $newRuleIds);
return $authList ? : [];
}
/**
* 任务列表统计
* @author yykun
* @return
*/
public function classList($work_id)
{
$classList = Db::name('WorkTaskClass')->where(['status' => 1,'work_id' => $work_id])->order('order_id asc')->select();
$taskarray = array();
foreach ($classList as $k => $v) {
$task_list = [];
$task_list = db('task')->where(['work_id' => $work_id,'class_id' => $v['class_id'],'is_archive' => 0,'ishidden' => 0])->field('is_archive,status')->select();
$allTask = 0;
$undoneTask = 0;
$doneTask = 0;
foreach ($task_list as $kk => $vv) {
$allTask += 1;
if ($vv['status'] == 1) {
$undoneTask += 1;
continue;
}
if ($vv['status'] == 5) {
$doneTask += 1;
continue;
}
}
$classList[$k]['allTask'] = $allTask ? : 0;
$classList[$k]['undoneTask'] = $undoneTask ? : 0;
$classList[$k]['doneTask'] = $doneTask ? : 0;
}
return $classList ? : [];
}
/**
* 任务标签统计
* @author yykun
* @return
*/
public function labelList($work_id,$labelIds = array())
{
if ($labelIds) {
$labelList = [];
$i = 0;
foreach ($labelIds as $k => $v) {
$labledet = [];
$task_list = [];
$labledet = Db::name('WorkTaskLable')->where(['lable_id' => $v])->find();
$task_list = Db::name('Task')->where(['lable_id' => ['like','%,'.$v.',%'],'work_id' => $work_id,'is_archive' => 0,'ishidden' => 0])->field('status,task_id')->select();
$allTask = 0;
$undoneTask = 0;
$doneTask = 0;
foreach ($task_list as $kk => $vv) {
if ($vv['status'] !== 3) $allTask += 1;
if ($vv['status'] == 1) {
$undoneTask += 1;
continue;
}
if ($vv['status'] == 5) {
$doneTask += 1;
continue;
}
}
$labelList[$i]['allTask'] = $allTask ? : 0;
$labelList[$i]['undoneTask'] = $undoneTask ? : 0;
$labelList[$i]['doneTask'] = $doneTask ? : 0;
$labelList[$i]['lablename'] = $labledet['name'];
$i++;
}
}
return $labelList ? : [];
}
}