project/app/Http/Controllers/Api/ReportController.php

<?php

namespace App\Http\Controllers\Api;

use App\Http\Controllers\Controller;
use App\Module\Base;
use App\Module\Users;
use DB;
use Request;
use App\Task;

/**
 * @apiDefine report
 *
 * 汇报
 */
class ReportController extends Controller
{
    public function __invoke($method, $action = '')
    {
        $app = $method ? $method : 'main';
        if ($action) {
            $app .= "__" . $action;
        }
        return (method_exists($this, $app)) ? $this->$app() : Base::ajaxError("404 not found (" . str_replace("__", "/", $app) . ").");
    }

    /**
     * 获取内容
     *
     * @apiParam {Number} id           数据ID
     */
    public function content()
    {
        $row = Base::DBC2A(DB::table('report_content')->select(['rid', 'content'])->where('rid', intval(Request::input('id')))->first());
        if (empty($row)) {
            return Base::retError('内容不存在或已被删除！');
        }
        return Base::retSuccess('success', $row);
    }

    /**
     * {post} 获取模板、保存、发送、删除
     *
     * @apiParam {String} type           类型
     * - 日报
     * - 周报
     * @apiParam {Number} [id]          数据ID
     * @apiParam {String} [act]         请求方式
     * - submit: 保存
     * - send: 仅发送
     * - delete: 删除汇报
     * - else: 获取
     * @apiParam {String} [send]        是否发送（1:是），仅act=submit且未发送过的有效
     * @apiParam {Object} [D]           Request Payload 提交
     * - title: 标题
     * - ccuser: 抄送人
     * - content: 内容
     */
    public function template()
    {
        $user = Users::authE();
        if (Base::isError($user)) {
            return $user;
        } else {
            $user = $user['data'];
        }
        //
        $id = intval(Base::getPostValue('id'));
        $act = trim(Base::getPostValue('act'));
        $type = trim(Base::getPostValue('type'));
        if (!in_array($type, ['日报', '周报'])) {
            return Base::retError('参数错误！');
        }
        $dateTitle = "";
        //
        $whereArray = [];
        $whereArray[] = ['username', '=', $user['username']];
        if ($id > 0) {
            $whereArray[] = ['id', '=', $id];
        } else {
            switch ($type) {
                case "日报":
                    $whereArray[] = ['type', '=', '日报'];
                    $whereArray[] = ['date', '=', date("Ymd")];
                    $dateTitle = date("Y-m-d");
                    break;
                case "周报":
                    $whereArray[] = ['type', '=', '周报'];
                    $whereArray[] = ['date', '=', date("W")];
                    $dateTitle = date("Y年m月") . "第" . Base::getMonthWeek() . "周";
                    break;
            }
        }
        //
        $reportDetail = Base::DBC2A(DB::table('report_lists')->where($whereArray)->first());
        if ($id > 0 && empty($reportDetail)) {
            return Base::retError('没有相关的数据！');
        }
        if ($act == 'send') {
            if (empty($reportDetail)) {
                return Base::retError('没有相关的数据或已被删除！');
            }
            $ccuser = Base::string2array($reportDetail['ccuser']);
            DB::table('report_ccuser')->where(['rid' => $reportDetail['id']])->update(['cc' => 0]);
            foreach ($ccuser AS $ck => $cuser) {
                if (!$cuser) {
                    unset($ccuser[$ck]);
                    continue;
                }
                DB::table('report_ccuser')->updateOrInsert([
                    'rid' => $reportDetail['id'],
                    'username' => $cuser,
                    'indate' => Base::time()
                ], [
                    'cc' => 1
                ]);
            }
            DB::table('report_lists')->where('id', $reportDetail['id'])->update([
                'status' => '已发送',
                'ccuser' => Base::array2string($ccuser)
            ]);
            $reportDetail['ccuser'] = implode(',', $ccuser);
            $reportDetail['ccuserArray'] = explode(',', $reportDetail['ccuser']);
            return Base::retSuccess('发送成功！', array_merge($reportDetail, [
                'ccuserAgain' => $reportDetail['status'] == '已发送'
            ]));
        } elseif ($act == 'delete') {
            if (empty($reportDetail)) {
                return Base::retError('没有相关的数据或已被删除！');
            }
            if ($reportDetail['status'] == '已发送') {
                return Base::retError('汇报已发送，无法删除！');
            }
            DB::table('report_lists')->where('id', $reportDetail['id'])->delete();
            DB::table('report_ccuser')->where('rid', $reportDetail['id'])->delete();
            DB::table('report_content')->where('rid', $reportDetail['id'])->delete();
            return Base::retSuccess('删除成功！');
        } elseif ($act == 'submit') {
            if (mb_strlen(Base::getPostValue('title')) < 2 || mb_strlen(Base::getPostValue('title')) > 100) {
                return Base::retError('标题限制2-100个字！');
            }
            if (empty($reportDetail)) {
                DB::table('report_lists')->insert([
                    'username' => $user['username'],
                    'title' => Base::getPostValue('title'),
                    'type' => $type,
                    'status' => '未发送',
                    'date' => $type=='日报'?date("Ymd"):date("W"),
                    'indate' => Base::time(),
                ]);
                $reportDetail = Base::DBC2A(DB::table('report_lists')->where($whereArray)->first());
            }
            if (empty($reportDetail)) {
                return Base::retError('系统繁忙，请稍后再试！');
            }
            //
            $ccuserArr = explode(",", Base::getPostValue('ccuser'));
            $send = $reportDetail['status'] == '已发送' ? 1 : intval(Base::getPostValue('send'));
            $ccuserAgain = $reportDetail['status'] == '已发送';
            if ($send) {
                DB::table('report_ccuser')->where(['rid' => $reportDetail['id']])->update(['cc' => 0]);
                foreach ($ccuserArr AS $ck => $cuser) {
                    if (!$cuser) {
                        unset($ccuserArr[$ck]);
                        continue;
                    }
                    DB::table('report_ccuser')->updateOrInsert([
                        'rid' => $reportDetail['id'],
                        'username' => $cuser,
                        'indate' => Base::time()
                    ], [
                        'cc' => 1
                    ]);
                }
                $reportDetail['status'] = '已发送';
            }
            //
            DB::table('report_lists')->where('id', $reportDetail['id'])->update([
                'title' => Base::getPostValue('title'),
                'status' => $send ? '已发送' : '未发送',
                'ccuser' => Base::array2string($ccuserArr)
            ]);
            DB::table('report_content')->updateOrInsert(['rid' => $reportDetail['id']], ['content' => Base::getPostValue('content')]);
            //
            $reportDetail = array_merge($reportDetail, [
                'ccuserAgain' => $ccuserAgain,
                'ccuser' => $ccuserArr,
                'title' => Base::getPostValue('title'),
                'content' => Base::getPostValue('content'),
            ]);
        }
        if (empty($reportDetail)) {
            $startTime = $type == '日报' ? strtotime(date('Y-m-d 00:00:00')) : strtotime(date('Y-m-d 00:00:00', strtotime('this week')));
            $finishTime = $type == '日报' ? strtotime(date('Y-m-d 23:59:59')) : strtotime(date('Y-m-d 23:59:59', strtotime('last day next week')));

            //zmw 修改
            $list = Task::where(function($query) use ($user){
                return $query->where('username',$user['username'])->orwhere('createuser',$user['username']);
            })->where('delete',0)->with(['subtask'=>function($query) {$query->where('delete',0);}])->get()->toArray();

            $completeContent = '';//已完成的任务
            $unfinishedContent = '';//未完成的任务

            foreach ($list as $k => $v){
                if($v['complete'] == 1 && $v['completedate'] >= $startTime && $v['completedate'] <= $finishTime){
                    //父任务标记已完成，不管子任务是否有完成，统一放到已完成内
                    $pre = $type == '周报' ? ('<span>[周' . ['日', '一', '二', '三', '四', '五', '六'][date('w')] . ']</span>&nbsp;') : '';
                    $completeContent .= '<li>' . $pre . $v['title'] . '</li>';
                    if(count($v['subtask']) > 0){
                        $completeContent .= '<ol>';
                        foreach ($v['subtask'] as $key => $value){
                            $completeContent .= '<li>' . $value['detail'] . '</li>';
                        }
                        $completeContent .= '</ol>';
                    }
                }

                if($v['complete'] == 0 && $v['enddate'] <= $finishTime){
                    //父任务未标记已完成，可能实际已完成，但忘记置父任务状态，也可能后续还会增加子任务，故统一放未完成，对父任务未完成，但下面已经完成的子任务做删除线
                    $pre = $v['enddate'] > 0 && $v['enddate'] < time() ? '<span style="color:#ff0000;">[超期]</span>&nbsp;' : '';
                    $unfinishedContent .= '<li>' . $pre . $v['title'] . '</li>';
                    if(count($v['subtask']) > 0){
                        $unfinishedContent .= '<ol>';
                        foreach ($v['subtask'] as $key => $value){
                            $unfinishedContent .= '<li>';
                            if($value['status'] == 'complete'){
                                $unfinishedContent .= "<span style='text-decoration: line-through;'>" .$value['detail'] . "</span>";
                            }else{
                                $unfinishedContent .= $value['detail'];
                            }
                            $unfinishedContent .= '</li>';
                        }
                        $unfinishedContent .= '</ol>';
                    }
                }
            }

            if (empty($completeContent)) {
                $completeContent = '<li>&nbsp;</li>';
            }

            if (empty($unfinishedContent)) {
                $unfinishedContent = '<li>&nbsp;</li>';
            }

            //
            $reportDetail['title'] = ($user['nickname'] ?: $user['username']) . '的' . $type . '[' . $dateTitle . ']';
            $reportDetail['ccuser'] = '';
            $reportDetail['content'] = '<h2>已完成工作</h2><ol>' . $completeContent . '</ol><h2>未完成的工作</h2><ol>' . $unfinishedContent . '</ol>';
            $reportDetail['status'] = '未保存';
        } else {
            $reportDetail['ccuser'] = implode(',', Base::string2array($reportDetail['ccuser']));
            if (!isset($reportDetail['content'])) {
                $reportDetail['content'] = DB::table('report_content')->select(['content'])->where('rid', $reportDetail['id'])->value('content');
            }
        }
        $reportDetail['ccuserAgain'] = isset($reportDetail['ccuserAgain']) ? $reportDetail['ccuserAgain'] : false;
        $reportDetail['ccuserArray'] = explode(',', $reportDetail['ccuser']);
        return Base::retSuccess($act == 'submit' ? '保存成功！' : 'success', $reportDetail);
    }

    /**
     * 我的汇报
     *
     * @apiParam {Number} [page]                当前页，默认:1
     * @apiParam {Number} [pagesize]            每页显示数量，默认:20，最大:100
     */
    public function my()
    {
        $user = Users::authE();
        if (Base::isError($user)) {
            return $user;
        } else {
            $user = $user['data'];
        }
        //
        $whereArray = [];
        $whereArray[] = ['username', '=', $user['username']];
        if (trim(Request::input('username'))) {
            $whereArray[] = ['username', '=', trim(Request::input('username'))];
        }
        if (in_array(trim(Request::input('type')), ['日报', '周报'])) {
            $whereArray[] = ['type', '=', trim(Request::input('type'))];
        }
        $indate = Request::input('indate');
        if (is_array($indate)) {
            if ($indate[0] > 0) $whereArray[] = ['indate', '>=', Base::dayTimeF($indate[0])];
            if ($indate[1] > 0) $whereArray[] = ['indate', '<=', Base::dayTimeE($indate[1])];
        }
        //
        $orderBy = '`indate` DESC,`id` DESC';
        $sorts = Base::json2array(Request::input('sorts'));
        if (in_array($sorts['order'], ['asc', 'desc'])) {
            switch ($sorts['key']) {
                case 'date':
                case 'indate':
                    $orderBy = '`' . $sorts['key'] . '` ' . $sorts['order'] . ',`id` DESC';
                    break;
            }
        }
        //
        $lists = DB::table('report_lists')
            ->where($whereArray)
            ->orderByRaw($orderBy)
            ->paginate(Base::getPaginate(100, 20));
        $lists = Base::getPageList($lists);
        if ($lists['total'] == 0) {
            return Base::retError('未找到任何相关的汇报', $lists);
        }
        foreach ($lists['lists'] AS $key => $item) {
            $lists['lists'][$key]['ccuser'] = Base::string2array($item['ccuser']);
        }
        return Base::retSuccess('success', $lists);
    }

    /**
     * 我的汇报
     *
     * @apiParam {String} [username]            汇报者用户名
     * @apiParam {Array} [indate]               汇报时间
     * @apiParam {String} [type]                类型
     * - 日报
     * - 周报
     * @apiParam {Object} [sorts]               排序方式，格式：{key:'', order:''}
     * - key: title|username|indate
     * - order: asc|desc
     * @apiParam {Number} [page]                当前页，默认:1
     * @apiParam {Number} [pagesize]            每页显示数量，默认:20，最大:100
     */
    public function receive()
    {
        $user = Users::authE();
        if (Base::isError($user)) {
            return $user;
        } else {
            $user = $user['data'];
        }
        //
        $whereArray = [];
        $whereArray[] = ['report_ccuser.username', '=', $user['username']];
        $whereArray[] = ['report_ccuser.cc', '=', 1];
        if (trim(Request::input('username'))) {
            $whereArray[] = ['report_lists.username', '=', trim(Request::input('username'))];
        }
        if (in_array(trim(Request::input('type')), ['日报', '周报'])) {
            $whereArray[] = ['report_lists.type', '=', trim(Request::input('type'))];
        }
        $indate = Request::input('indate');
        if (is_array($indate)) {
            if ($indate[0] > 0) $whereArray[] = ['report_lists.indate', '>=', Base::dayTimeF($indate[0])];
            if ($indate[1] > 0) $whereArray[] = ['report_lists.indate', '<=', Base::dayTimeE($indate[1])];
        }
        //
        $builder = DB::table('report_lists')
            ->join('report_ccuser', 'report_lists.id', '=', 'report_ccuser.rid')
            ->select(['report_lists.*', 'report_ccuser.indate as senddate'])
            ->where($whereArray);
        $sorts = Base::json2array(Request::input('sorts'));
        if (in_array($sorts['order'], ['asc', 'desc'])) {
            switch ($sorts['key']) {
                case 'title':
                case 'username':
                    $builder->orderBy($sorts['key'], $sorts['order']);
                    break;
                case 'indate':
                    $builder->orderBy('report_ccuser.indate', $sorts['order']);
                    break;
            }
        } else {
            $builder->orderByDesc('report_ccuser.indate');
            $builder->orderByDesc('report_ccuser.id');
        }
        //
        $builder->orderByDesc('date');
        $lists = $builder->paginate(Base::getPaginate(100, 20));
        $lists = Base::getPageList($lists);
        if ($lists['total'] == 0) {
            return Base::retError('未找到任何相关的汇报', $lists);
        }
        foreach ($lists['lists'] AS $key => $item) {
            $lists['lists'][$key]['ccuser'] = Base::string2array($item['ccuser']);
        }
        return Base::retSuccess('success', $lists);
    }

    /**
     * 获取我上次抄送的人
     * @return array|mixed
     */
    public function prevcc()
    {
        $user = Users::authE();
        if (Base::isError($user)) {
            return $user;
        } else {
            $user = $user['data'];
        }
        //
        $rid = DB::table('report_ccuser')
            ->join('report_lists', 'report_lists.id', '=', 'report_ccuser.rid')
            ->where('report_lists.username', $user['username'])
            ->orderByDesc('report_ccuser.id')
            ->value('rid');
        if (empty($rid)) {
            return Base::retError('没有相关数据！');
        }
        $lists = Base::DBC2A(DB::table('report_ccuser')->select(['username'])->where('rid', $rid)->pluck('username'));
        if (empty($lists)) {
            return Base::retError('没有相关数据！');
        }
        return Base::retSuccess('success', [
            'lists' => $lists
        ]);
    }
}