colleague / study-project · Files

<?php
/*/**
 * 【考试中心-后台】导出考试已参与和未参与人员记录接口
 * @author: houyingcai
 * @email:  594609175@qq.com
 * @date :  2017-06-01 09:41:09
 * @version $Id$
 */

namespace Apicp\Controller\Export;

use Common\Common\Department;
use Common\Common\ExamHelper;
use Common\Common\ExportDownload;
use Common\Common\User;
use Common\Service\AnswerService;
use Common\Service\PaperService;
use Com\PythonExcel;


class JoinListController extends AbstractController
{

    /** @var PaperService */
    protected $paper_serv;
    /** @var AnswerService */
    protected $answer_serv;
    /** @var Department */
    protected $department;

    protected $_require_login = false;

    public function before_action($action = '')
    {
        if (!parent::before_action($action)) {
            return false;
        }

        $this->paper_serv = new PaperService();
        $this->answer_serv = new AnswerService();
        $this->department = &Department::instance();

        return true;
    }

    public function Index()
    {

        $params = I('post.');

        // 试卷id为空，返回提示""
        if (!$params['ep_id']) {
            E('_EMPTY_EP_ID');
        }

        $types = array(
            ExamHelper::HAS_JOINED,
            ExamHelper::NOT_JOINED
        );

        // 导出类型不正确
        if (!in_array($params['type'], $types)) {

            E('_ERR_EXPORT_TYPE');
        }

        // 获取试卷信息
        $paper = $this->paper_serv->get($params['ep_id']);

        // 试卷不存在
        if (empty($paper)) {

            E('_ERR_PAPER_NOT_FOUND');
        }

        // 拼接数组
        if (!empty($params['dpIds'])) {
            $params['dpIds'] = explode(';', $params['dpIds']);

        }

        // 拼接数组
        if (!empty($params['end_time'])) {

            $params['end_time'] = explode(';', $params['end_time']);
        }

        // 初始化列表数据
        $lists = [];
        $userlist = [];

        // 【已参与】人员列表（测评试卷）
        if (
            $params['type'] == ExamHelper::HAS_JOINED &&
            $paper['paper_type'] == PaperService::EVALUATION_PAPER_TYPE
        ) {

            // 组装查询条件
            $conds = $this->answer_serv->get_conditions($paper, $params);
            // 【考试完成时间】
            if (isset($params['end_time']) && !empty($params['end_time']) && is_array($params['end_time'])) {

                $end_time = $params['end_time'];
                $end_time1 = $end_time[0];
                $end_time2 = $end_time[1];
                if ($end_time1 && $end_time2) {

                    $conds['my_end_time>=?'] = $end_time1;
                    $conds['my_end_time<=?'] = $end_time2;
                }
            }

            // 最高分记录
            $conds['is_score_top'] = PaperService::IS_SCORE_TOP_TRUE;

            // 【排序】
            $sort = $params['sort'];

            // 成绩升序
            if (ExamHelper::SORT_ASC == $sort) {

                $order_by = array(
                    'my_score' => 'ASC',
                    'created' => 'ASC'
                );
            } else { // 成绩降序

                $order_by = array(
                    'my_score' => 'DESC',
                    'created' => 'ASC'
                );
            }

            // 参与这场考试的人员的考试信息
            $lists = $this->answer_serv->list_by_conds($conds, null, $order_by);
            // 参与考试的所有人的UID
            $uids = array_column($lists, 'uid');

            // 参与考试的人员的详细信息列表
            if (!empty($uids)) {

                $userlist = $this->answer_serv->getUser($uids);
            }

            $new_uids = [];
            // 格式化返回字段信息
            foreach ($lists as $key => &$val) {
                if (in_array($val['uid'], $new_uids)) {
                    // 如果存在该用户的记录，则跳过
                    unset($lists[$key]);
                    continue;
                } else {
                    $new_uids[] = $val['uid'];
                }

                $res_dpIds = array_column($userlist[$val['uid']]['dpName'], 'dpId');
                $dpNames = '';
                if (!empty($res_dpIds)) {

                    $dpNames = $this->ge_user_dp_name($res_dpIds);
                }
                $val['ranking'] = intval($key + 1);
                $val['memMobile'] = $userlist[$val['uid']]['memMobile']; //手机号
                $val['username'] = $userlist[$val['uid']]['memUsername'];
                $val['dpName'] = $dpNames;
                $val['memJob'] = $userlist[$val['uid']]['memJob']; // 岗位
                $val['memRole'] = $userlist[$val['uid']]['memRole']; // 角色
                $val['memTag'] = $userlist[$val['uid']]['memTag']; // 标签
                $val['begin_time'] = $paper['begin_time'];
                $val['end_time'] = $paper['end_time'];
            }
        }

        // 【已参与】人员列表(模拟试卷)
        if (
            $params['type'] == ExamHelper::HAS_JOINED &&
            $paper['paper_type'] == PaperService::SIMULATION_PAPER_TYPE
        ) {

            // 组装查询条件
            $conds = $this->answer_serv->get_conditions($paper, $params);
            // 【考试完成时间】
            if (isset($params['end_time']) && !empty($params['end_time']) && is_array($params['end_time'])) {

                $end_time = $params['end_time'];
                $end_time1 = $end_time[0];
                $end_time2 = $end_time[1];
                if ($end_time1 && $end_time2) {

                    $conds['my_end_time>=?'] = $end_time1;
                    $conds['my_end_time<=?'] = $end_time2;
                }
            }

            // 排序
            $sort = $params['sort'];

            // 成绩升序
            if (ExamHelper::SORT_ASC == $sort) {

                $order_by = array(
                    'my_max_score' => 'ASC',
                    'created' => 'ASC'
                );
            } else { // 成绩降序

                $order_by = array(
                    'my_max_score' => 'DESC',
                    'created' => 'ASC'
                );
            }

            // 分页
            $page_option = null;

            // 返回字段
            $fields = 'ea_id,uid,my_score,created,my_begin_time,my_end_time';
            // 参与考试的人员的考试信息
            $lists = $this->answer_serv->get_mock_join_list($conds, $page_option, $order_by, $fields);
            // 参与考试的所有人的UID
            $uids = array_column($lists, 'uid');

            // 参与考试的人员的详细信息列表
            if (!empty($uids)) {

                $userlist = $this->answer_serv->getUser($uids);
            }

            // 格式化返回字段信息
            foreach ($lists as $key => &$val) {

                $val['ranking'] = intval($key + 1);
                $val['username'] = $userlist[$val['uid']]['memUsername'];
                $res_dpIds = array_column($userlist[$val['uid']]['dpName'], 'dpId'); // 获取用户部门信息

                $dpNames = '';
                if (!empty($res_dpIds)) {
                    $dpNames = $this->ge_user_dp_name($res_dpIds);
                }
                $val['dpName'] = $dpNames;
                $val['memMobile'] = $userlist[$val['uid']]['memMobile']; //手机号
                $val['memJob'] = $userlist[$val['uid']]['memJob']; // 岗位
                $val['memRole'] = $userlist[$val['uid']]['memRole']; // 角色
                $val['memTag'] = $userlist[$val['uid']]['memTag']; // 标签
                $val['begin_time'] = $val['my_begin_time'];
                $val['end_time'] = $val['my_end_time'];
            }
        }

        // 【未参与】人员列表
        if ($params['type'] == ExamHelper::NOT_JOINED) {

            // 查询条件
            $conds = array(
                'epc_id' => $params['ep_id'],
                'er_type' => AnswerService::RIGHT_PAPER,
            );

            // 获取未参与考试人员列表
            $unjoin_data = $this->answer_serv->get_unjoin_data($conds, $params['ep_id'], $paper['is_all']);

            // 未参加人的列表
            $unjoin_list = $unjoin_data['unjoin_list'];

            // 【部门】
            if (isset($params['dpIds']) && !empty($params['dpIds']) && is_array($params['dpIds'])) {

                $params_dpids = $params['dpIds'];
                $dpServ = &Department::instance();
                // 取子级部门ID
                $dp_ids = $dpServ->list_childrens_by_cdid($params_dpids, true);
                sort($dp_ids);

                $conditions['dpIdList'] = $dp_ids;
            }

            // 【岗位】
            if (isset($params['memJob']) && $params['memJob']) {

                $conditions['jobIdList'] = [$params['memJob']];
            }

            // 【角色】
            if (isset($params['memRole']) && $params['memRole']) {

                $conditions['roleIdList'] = [$params['memRole']];
            }

            // 【标签】
            if (isset($params['memTag']) && $params['memTag']) {

                $conditions['tagIdList'] = [$params['memTag']];
            }

            // 【员工名称】
            if (isset($params['memUsername']) && $params['memUsername']) {

                $conditions['memUsername'] = $params['memUsername'];

            }

            // 如果存在查询条件
            if (!empty($conditions)) {
                $user_select_list = User::instance()->listAllBasic($conditions);

                if (!empty($user_select_list)) {
                    $unjoin_list = array_intersect($unjoin_list, array_column($user_select_list, 'memUid'));
                } else {
                    $unjoin_list = [];
                }
            }

            // 如果存在未读人员
            if (!empty($unjoin_list)) {

                sort($unjoin_list);
                // 获取部分数据
                $list = User::instance()->listAll(['memUids' => $unjoin_list]);
                // 获取未读列表
                $user_list = array_combine_by_key($list, 'memUid');

                // 处理数据
                $lists = $this->nojoin_data($user_list, $paper);
            }
        }

        // 执行导出
        $this->_download($lists, $paper['paper_type'], $params['type']);

        return true;
    }

    /**
     * 处理未参加人员数据
     *
     * @param array $members 所有未参加的人员
     * @param array $paper 考卷详情
     *
     * @return array 未参加人员
     */
    private function nojoin_data($members, $paper)
    {
        $status = '';
        switch ($paper['exam_status']) {
            // 已发布
            case PaperService::PAPER_PUBLISH:
                // 【已开始】
                if (
                    $paper['begin_time'] < MILLI_TIME &&
                    ($paper['end_time'] >= MILLI_TIME || $paper['end_time'] == 0)
                ) {

                    $status = '已开始';
                }

                // 【已结束】
                if ($paper['end_time'] > 0 && $paper['end_time'] < MILLI_TIME) {

                    $status = '已结束';
                }
                break;
            // 已终止
            case PaperService::PAPER_STOP:
                $status = '已终止';
                break;

            default:
        }

        $data = [];
        foreach ($members as $key => $value) {

            $dpNames = '';
            $res_dpIds = array_column($value['dpName'], 'dpId');

            if (!empty($res_dpIds)) {

                $dpNames = $this->ge_user_dp_name($res_dpIds);

            }

            $data[] = array(
                'uid' => $key,
                'username' => $value['memUsername'],
                'memMobile' => $value['memMobile'],
                'dpName' => $dpNames,
                'memJob' => $value['memJob'],
                'memRole' => $value['memRole'],
                'memTag' => $value['memTag'],
                'created' => $paper['begin_time'] ? $paper['begin_time'] : '',
                'memCreated' => $value['memCreated'] ? $value['memCreated'] : '',
                'exam_status' => $status,
            );
        }

        return $data;
    }

    /**
     * 根据部门IDS获取所对应部门路径集合
     * @param array $res_dpIds 部门IDS
     * @return string
     */
    protected function ge_user_dp_name($res_dpIds = [])
    {
        // 初始化部门名称
        $dpNames = '';

        // 部门ID集合存在
        if (!empty($res_dpIds)) {

            // 初始化部门路径
            $dp_path = [];

            // 便利部门ID
            foreach ($res_dpIds as $id) {

                // 获取部门路径
                $dp_path[] = $this->department->getCdNames($id);
            }

            // 拼接部门名称
            $dpNames = implode(';', $dp_path);
        }

        return $dpNames;
    }

    /**
     * 导出模板
     *
     * @param array $list 列表数据
     * @param int $paper_type 试卷类型
     * @param int $export_type 导出类型
     */
    private function _download($list = [], $paper_type = 0, $export_type = 0)
    {
        // 初始化导出数据
        $file_name = '';
        $title = [];
        $row_data = [];

        // 【1】测评试卷（已参与）
        if (
            $export_type == ExamHelper::HAS_JOINED &&
            $paper_type == PaperService::EVALUATION_PAPER_TYPE
        ) {

            $file_name = '测评试卷已参与考试人员统计' . date('_YmdHi');

            $title = array(
                '排名',
                '姓名',
                '手机号',
                '组织',
                '角色',
                '岗位',
                '考试时间',
                '用时',
                '分数',
                '状态',
            );

            foreach ($list as $k => $v) {

                $my_time = '';
                $begin_time = rgmdate(strval($v['my_begin_time']), 'Y-m-d H:i');
                $end_time = rgmdate(strval($v['my_begin_time'] + $v['my_time']), 'Y-m-d H:i');

                $temTime = ceil($v['my_time'] / 1000);
                $h = floor($temTime / 3600);
                if ($h != 0) {
                    $my_time .= $h . '时';
                }

                $m = floor($temTime % 3600 / 60);
                if ($m != 0) {
                    $my_time .= $m . '分';
                }
                $s = $temTime % 60;
                if ($s != 0) {
                    $my_time .= $s . '秒';
                }

                // 判断是否批阅
                $my_is_pass = $v['my_is_pass'] ? '通过' : '未通过';

                // 待批阅
                if ($v['answer_status'] == PaperService::READ_WAITING) {

                    $my_is_pass = '待批阅';
                }

                $row_data[] = array(
                    $v['ranking'],
                    $v['username'],
                    $v['memMobile'],
                    $v['dpName'],
                    $v['memRole'],
                    $v['memJob'],
                    $begin_time . '-' . $end_time,
                    $my_time,
                    $v['my_score'],
                    $my_is_pass
                );
            }
        }

        // 【2】模拟试卷（已参与）
        if (
            $export_type == ExamHelper::HAS_JOINED &&
            $paper_type == PaperService::SIMULATION_PAPER_TYPE
        ) {

            $file_name = '模拟试卷已参与考试人员统计' . date('_YmdHi');
            $title = array(
                '姓名',
                '手机号',
                '组织',
                '角色',
                '岗位',
                '考试时间',
                '参与次数',
                '历史最高分',
                '排名',
            );

            foreach ($list as $k => $v) {
                $begin_time = !empty($v['begin_time']) ? rgmdate(strval($v['begin_time']), 'Y-m-d H:i') : '';
                $end_time = !empty($v['end_time']) ? rgmdate(strval($v['end_time']), 'Y-m-d H:i') : '';
                $row_data[] = array(
                    $v['username'],
                    $v['memMobile'],
                    $v['dpName'],
                    $v['memRole'],
                    $v['memJob'],
                    $begin_time . '-' . $end_time,
                    $v['join_count'],
                    $v['my_max_score'],
                    $v['ranking'],
                );
            }
        }

        // 【3】未参与考试
        if ($export_type == ExamHelper::NOT_JOINED) {

            $file_name = '未参与考试人员统计' . date('_YmdHi');
            $title = array(
                '姓名',
                '手机号',
                '组织',
                '角色',
                '岗位',
                '创建时间',
                '系统录入时间',
                '试卷状态',
            );

            foreach ($list as $k => $v) {
                $row_data[] = array(
                    $v['username'],
                    $v['memMobile'],
                    $v['dpName'],
                    $v['memRole'],
                    $v['memJob'],
                    $v['created'] ? rgmdate(strval($v['created']), 'Y-m-d H:i') : '',
                    $v['memCreated'] ? rgmdate(strval($v['memCreated']), 'Y-m-d H:i') : '',
                    $v['exam_status'],
                );
            }
        }

        // Python导出excel
        $realpath = ExportDownload::get_down_dir($this->_login->user['eaId'] . microtime(true)) . $file_name . ".xls";
        $ret = PythonExcel::instance()->write($realpath, $title, $row_data);
        if ($ret) {

            $conditon = [
                'title' => $file_name,
                'ea_id' => $this->_login->user['eaId'],
                'username' => $this->_login->user['eaRealname'],
                'type' => ExportDownload::EXCEL_TYPE,
                'url' => $realpath
            ];

            ExportDownload::insert_down_load($conditon);
        }

        return true;
    }
}