colleague / study-project · Files

<?php
/**
 * Created by PhpStorm.
 * User: wanghuan
 * Date: 2017/11/17
 * Time: 11:28
 */

namespace Apicp\Controller\Export;

use Com\PythonExcel;
use Common\Common\ExportDownload;
use Common\Common\Helper;
use Common\Common\User;
use Common\Service\ActivityService;
use Common\Service\CommentService;
use Common\Service\PacketrecordService;

class CommentListController extends \Apicp\Controller\AbstractController
{

    public $success_money_total = 0; // 领取成功的总金额
    public $success_money_system = 0; // 领取成功的随机红包的总金额
    public $success_money_admin = 0; // 领取成功的定向红包的总金额
    public $success_money_admin_num = 0; // 领取成功的定向红包的次数
    public $ing_money_total = 0;   // 待领取的总金额
    public $ing_money_system = 0; // 待领取的随机红包的总金额
    public $ing_money_admin = 0; // 待领取的定向红包的总金额
    public $ing_money_admin_num = 0; // 待领取的定向红包的次数
    /** @var ActivityService */
    protected $activity_s;

    public $comment_id = 0; // 帖子id

    public function before_action($action = '')
    {

        if (!parent::before_action($action)) {

            return false;
        }

        // 实例化活动信息表
        $this->activity_s = new ActivityService();
        return true;
    }

    // 导出回帖列表接口
    public function Index()
    {

        // 活动id
        $ac_id = I('post.ac_id');
        $username = I('post.username');
        $start_time = I('post.start_time');
        $end_time = I('post.end_time');
        if (empty($ac_id)) {
            // 活动id为空
            E('_EMPTY_ACTIVITY_ID');
        }

        $activity = $this->activity_s->get($ac_id);

        if (empty($activity)) {

            E('_ERR_ACTIVITY_DATA');

        }

        // 获取活动状态
        $status = $this->activity_s->activity_status($activity['activity_status'], $activity['begin_time'],
            $activity['end_time']);

        if (intval($status) < 3) {
            // 如果是草稿和未开始
            return true;
        }

        // 导出列表导出
        $this->download_answers($activity, $username, $start_time, $end_time);
    }


    /**
     * 导出发帖列表导出
     *
     * @param array $activity 活动信息
     * @param string $user_name 搜索的用户名
     * @param string $start_time 开始时间
     * @param string $end_time 结束时间
     * @return bool
     */
    protected function download_answers($activity = [], $user_name = '', $start_time = '', $end_time = '')
    {

        // 查询条件
        $condition = [
            'ac_id' => $activity['ac_id'],
        ];

        // 如果查询人员
        if (!empty($user_name)) {

            $uids = $this->activity_s->get_username_uid($user_name);
            // 组装用户查询条件
            $condition['uid'] = $uids;
        }

        // 如果开始时间和结束时间存在
        if (!empty($start_time) && !empty($end_time)) {
            $condition['created >=?'] = $start_time;
            $condition['created <=?'] = $end_time;
        }

        // 排序:发布时间倒序
        $order_option = [
            'comment_id' => 'DESC',
        ];

        // 查询字段
        $fields = 'comment_id,ac_id,uid,check_status,ext_fields,created,ext_fields';

        $comment_s = new CommentService();
        // 发帖列表
        $comment_list = $comment_s->list_by_conds($condition, null, $order_option, $fields);
        $ext_fields = [];
        $list = [];
        if (!empty($comment_list)) {
            // 发帖人id集合
            $user_ids = array_unique(array_column($comment_list, 'uid'));
            sort($user_ids);

            // 获取发帖人信息
            $user_s = User::instance();
            $user_list = $user_s->listByUid($user_ids);

            // 实例化红包记录表
            $packet_records = new PacketrecordService();
            // 红包记录查询条件
            $reords_conds = [
                'ac_id' => $activity['ac_id'],
                'uid<>?' => '',
            ];

            // 排序:发布时间倒序
            $reords_order_option = [
                'cid' => 'DESC',
            ];

            // 查询参数
            $reords_field = 'rid,p_type,cid,rand_money,packet_status,parent_rid,regive_status';
            // 获取红包记录
            $reords_list = $packet_records->list_by_conds($reords_conds, null, $reords_order_option, $reords_field);

            // 数据格式化
            foreach ($comment_list as $comment) {

                // 部门名称
                $dp_names = '';
                // 用户信息
                $user_info = $user_list[$comment['uid']];
                if (empty($user_info)) {
                    // 如果用户被删除
                    $user_info = $user_s->getByUid($comment['uid']);
                }

                // 姓名
                $username = $user_info['memUsername'];
                // 电话
                $mobile = $user_info['memMobile'];
                // 部门名称
                $dpName = array_column($user_info['dpName'], 'dpName');

                if (!empty($dpName)) {

                    $dp_names = implode(',', $dpName);
                }

                $this->success_money_total = 0;
                $this->success_money_system = 0;
                $this->success_money_admin = 0;
                $this->success_money_admin_num = 0;

                $this->ing_money_total = 0;
                $this->ing_money_system = 0;
                $this->ing_money_admin = 0;
                $this->ing_money_admin_num = 0;

                $this->comment_id = $comment['comment_id'];

                if ($comment['check_status'] == 1) {
                    // 审核通过的才会有红包记录
                    array_filter($reords_list, function ($v) {

                        if ($v['packet_status'] == 0 && $v['cid'] == $this->comment_id) {
                            // 当前帖子待领取总金额
                            $this->ing_money_total += $v['rand_money'];
                            if ($v['p_type'] == 1) {
                                // 随机红包
                                $this->ing_money_system += $v['rand_money'];
                            } elseif ($v['p_type'] == 4) {
                                // 定向红包
                                $this->ing_money_admin += $v['rand_money'];
                                $this->ing_money_admin_num += 1;
                            }

                        } elseif ($v['packet_status'] == 1 && $v['cid'] == $this->comment_id) {
                            // 当前帖子领取成功金额
                            $this->success_money_total += $v['rand_money'];

                            if ($v['p_type'] == 1) {
                                // 随机红包
                                $this->success_money_system += $v['rand_money'];
                            } elseif ($v['p_type'] == 4) {
                                // 定向红包
                                $this->success_money_admin += $v['rand_money'];
                                $this->success_money_admin_num += 1;
                            }

                        }

                    });
                }

                // 如果有扩展字段
                if (!empty($comment['ext_fields'])) {
                    $ext_fields[] = $this->get_ext_fields(unserialize($comment['ext_fields']));
                }

                $list[] = [
                    'username' => $username,
                    'dp_names' => $dp_names,
                    'mobile' => $mobile,
                    'created' => rgmdate(strval($comment['created']), 'Y/m/d H:i'),
                    'check_status' => $this->get_check_status($comment['check_status']),
                    'success_money_total' => empty($this->success_money_total) ? '' : sprintf("%.2f",
                            $this->success_money_total / 100) . '元',
                    // 领取成功总金额
                    'success_money_system' => empty($this->success_money_system) ? '' : sprintf("%.2f",
                            $this->success_money_system / 100) . '元',
                    // 领取成功随机红包金额
                    'success_money_admin' => empty($this->success_money_admin) ? '' : sprintf("%.2f",
                            $this->success_money_admin / 100) . '元',
                    // 领取成功定向红包金额
                    'success_money_admin_num' => empty($this->success_money_admin_num) ? '' : $this->success_money_admin_num,
                    // 领取成功定向红包次数
                    'ing_money_total' => empty($this->ing_money_total) ? '' : sprintf("%.2f",
                            $this->ing_money_total / 100) . '元',
                    // 待领取红包总金额
                    'ing_money_system' => empty($this->ing_money_system) ? '' : sprintf("%.2f",
                            $this->ing_money_system / 100) . '元',
                    // 待领取随机红包金额
                    'ing_money_admin' => empty($this->ing_money_admin) ? '' : sprintf("%.2f",
                            $this->ing_money_admin / 100) . '元',
                    // 待领取定向红包金额
                    'ing_money_admin_num' => empty($this->ing_money_admin_num) ? '' : $this->ing_money_admin_num,
                    // 待领取定向红包次数
                ];
            }
        }

        unset($comment_list);
        unset($user_list);

        // 生成下载Excel
        $this->_download($list, $ext_fields, $activity, rgmdate(strval(MILLI_TIME), 'YmdHis'));
    }

    /**
     * 获取扩展字段从手机端获得的值
     * @param array $data 扩展字段数据
     * @return array
     */
    protected function get_ext_fields($data = [])
    {
        $list = [];
        // 遍历数据
        foreach ($data as $key => $v) {
            // 如果是文本类型或者时间类型
            if (Helper::EXT_FIELD_TEXT_TYPE == $v['type'] ||
                Helper::EXT_FIELD_TIME_HI_TYPE == $v['type'] ||
                Helper::EXT_FIELD_TIME_YMD_TYPE == $v['type'] ||
                Helper::EXT_FIELD_TIME_YMD_HI_TYPE == $v['type']
            ) {
                $list[] = $v['text'];
            }
            // 数字类型
            if (Helper::EXT_FIELD_NUMBER_TYPE == $v['type']) {
                $list[] = $v['text'] . $v['unit'];
            }
            // 单选类型或者多选类型
            if (Helper::EXT_FIELD_RADIO_TYPE == $v['type'] || Helper::EXT_FIELD_MULTI_SELECT_TYPE == $v['type']) {
                // 默认选中项
                $check = [];
                foreach ($v['options'] as $item) {
                    // 如果被选中
                    if (Helper::EXT_FIELD_CHECK == $item['value']) {
                        $check[] = $item['key'];
                    }
                }
                // 获取选中的值
                $list[] = implode(',', $check);
            }
        }

        return $list;
    }

    /**
     * 获取审核状态
     *
     * @param int $check_status
     *
     * @return string
     */
    protected function get_check_status($check_status = 0)
    {

        if ($check_status == 0) {
            return '待审核';
        } elseif ($check_status == 1) {
            return '已通过';
        } elseif ($check_status == 2) {
            return '未通过';
        }

        return '';
    }


    /**
     * 回答导出模板
     *
     * @param array $list 导出数据
     * @param array $ext_fields 扩展字段数据
     * @param array $activity 活动详情
     * @param string $file_name 文件名称
     *
     * @return bool
     */
    protected function _download($list = [], $ext_fields = [], $activity = [], $file_name)
    {
        // Excel 表头字段
        $title = [
            '姓名',
            '组织',
            '手机号',
            '发表时间'
        ];

        // 如果存在扩展字段
        if (!empty($activity['ext_fields'])) {
            // 扩展字段名称
            $ext_name = array_column(unserialize($activity['ext_fields']), 'name');
            $title = array_merge($title, $ext_name);
        }

        // 扩展字段后的部分
        $tail = [
            '审核状态',
            '已领取红包总金额',
            '已领取系统随机红包金额',
            '已领取手动定向红包金额',
            '已领取手动定向红包次数',
            '未领取红包总金额',
            '未领取系统随机红包金额',
            '未领取手动定向红包金额',
            '未领取手动定向红包次数',
        ];
        $title = array_merge($title, $tail);

        $rows = [];
        // 回帖数据处理
        foreach ($list as $key => $v) {

            // 将数组分割两个部门
            $rows[$key] = [
                $v['username'],
                $v['dp_names'],
                $v['mobile'],
                $v['created']
            ];
            // 扩展字段后的部分
            $tail_info = [
                $v['check_status'],
                $v['success_money_total'],
                $v['success_money_system'],
                $v['success_money_admin'],
                $v['success_money_admin_num'],
                $v['ing_money_total'],
                $v['ing_money_system'],
                $v['ing_money_admin'],
                $v['ing_money_admin_num'],
            ];

            // 如果存在扩展字段部分
            if (!empty($ext_fields)) {

                $rows[$key] = array_merge($rows[$key], $ext_fields[$key]);
            }
            $rows[$key] = array_merge($rows[$key], $tail_info);
        }

        unset($list);

        $file_title=$activity ['subject'] . '_评论列表_' . $file_name;
        // 生成Excel 下载
        $real_path = ExportDownload::get_down_dir($this->_login->user['eaId'] . microtime(true)) .$file_title . '.xls';

        $ret = PythonExcel::instance()->write($real_path, $title, $rows);

        if ($ret) {

            // header('Content-Description: File Transfer');
            // header('Content-Type: application/octet-stream');
            // header('Content-Disposition: attachment; filename=' . $file_name . '.xls');
            // header('Content-Transfer-Encoding: binary');
            // header('Expires: 0');
            // header('Cache-Control: must-revalidate, post-check=0, pre-check=0');
            // header('Pragma: public');
            // header('Content-Length: ' . filesize($real_path));
            // readfile($real_path);

            // 写入数据到下载中心
            $params = [
                'title' => $file_title,
                'ea_id' => $this->_login->user['eaId'],
                'username' => $this->_login->user['eaRealname'],
                'type' => ExportDownload::EXCEL_TYPE,
                'url' => $real_path,
            ];

            ExportDownload::insert_down_load($params);
        }

        return true;
    }

}