colleague / study-project · Files

<?php
/**
 * 应用安装时的消息回调
 * User: zhuxun37
 * Date: 16/8/11
 * Time: 下午3:44
 */

namespace Frontend\Controller\Callback;

use Common\Service\AnswerService;
use Common\Service\PaperService;
use Common\Service\SettingService;
use Think\Log;
use VcySDK\Cron;
use VcySDK\Service;

class InstallController extends AbstractController
{
    // 应用状态，可用
    const PLUGIN_STATE_AVAILABLE = 1;
    // 应用状态，不可用
    const PLUGIN_STATE_UNAVAILABLE = 2;

    /** @var AnswerService */
    protected $answer_serv;
    /** @var SettingService */
    protected $setting_serv;

    public function __construct()
    {
        parent::__construct();

        // 实例化答卷表
        $this->answer_serv = new AnswerService();
        // 实例化设置表
        $this->setting_serv = new SettingService();
    }

    public function Index()
    {
        Log::record(sprintf('---%s %s INSTALL START---', QY_DOMAIN, APP_IDENTIFIER), Log::INFO);
        Log::record(var_export($this->callBackData, true), Log::INFO);
        Log::record(sprintf('---%s %s INSTALL END ---', QY_DOMAIN, APP_IDENTIFIER), Log::INFO);

        $this->Install();
        exit('SUCCESS');
    }

    /**
     * 安装应用
     *
     * @author caijianhua
     *
     * @return void
     */
    public function Install()
    {
        // 安装考试统计定时任务
        $this->userCacheCronAdd();
        exit('SUCCESS');
    }

    /**
     * 卸载应用
     * @author caijianhua
     * @return void
     */
    public function Uninstall()
    {
        // 卸载考试统计定时任务
        $this->statisticsCronDelete();
        $this->userCacheCronDelete();
        exit('SUCCESS');
    }

    /**
     * 安装考试统计定时任务(弃用)
     *
     * @author caijianhua
     *
     * @return bool
     */
    protected function statisticsCronAdd()
    {
        $conditions_setting['key'] = 'exam_stistics';
        $setting = $this->setting_serv->get_by_conds($conditions_setting);
        $params = [
            'crRemark' => 'exam_stistics', // 考试统计
            'crCron' => '0 0/10 * * * ?',// 每分钟触发
            'crDescription' => '考试试卷数据统计处理',
            'crType' => '2',
            'crReqUrl' => oaUrl('Frontend/Callback/Statistics'), // 回调地址
            'crMonitorExecution' => 0,
            'crTimes' => '0'
        ];

        $cronSdk = new Cron(Service::instance());
        // 判断计划任务标识，如果不存在添加，存在更新
        if (empty($setting['value'])) {

            $crId_data = $cronSdk->add($params);
            if (!empty($crId_data)) {
                $crId = $crId_data['crId'];
                $data = [
                    'key' => 'exam_stistics',
                    'value' => $crId
                ];
                $this->setting_serv->insert($data);
                Log::record("add task: {$crId}", Log::INFO);
            }
        }

        return true;
    }

    /**
     * 卸载考试统计定时任务
     *
     * @author caijianhua
     *
     * @return bool
     */
    protected function statisticsCronDelete()
    {
        // 考试统计查询条件
        $conds['key'] = 'exam_stistics';
        $setting = $this->setting_serv->get_by_conds($conds);

        $crId = $setting['value'];
        // 判断计划任务标识是否存在
        if (!empty($crId)) {

            $cronSdk = new Cron(Service::instance());
            $cronSdk->delete($crId);
            Log::record("delete task: {$crId}", Log::INFO);
            // 删除定时任务
            $this->setting_serv->delete($setting['id']);
        }

        return true;
    }

    /**
     * 安装人员缓存更新
     *
     * @return bool
     */
    protected function userCacheCronAdd()
    {
        $conditions_setting['key'] = 'exam_user_cache';
        $setting = $this->setting_serv->get_by_conds($conditions_setting);
        $params = [
            'crRemark' => 'exam_user_cache', // 考试统计
            'crCron' => '0 0 0/1 * * ?',// 每小时触发
            'crDescription' => '考试人员缓存',
            'crType' => '2',
            'crReqUrl' => oaUrl('Frontend/Callback/UserCache'), // 回调地址
            'crMonitorExecution' => 0,
            'crTimes' => '0'
        ];

        $cronSdk = new Cron(Service::instance());
        // 判断计划任务标识，如果不存在添加，存在更新
        if (empty($setting['value'])) {

            $crId_data = $cronSdk->add($params);
            if (!empty($crId_data)) {
                $crId = $crId_data['crId'];
                $data = [
                    'key' => 'exam_user_cache',
                    'value' => $crId
                ];
                $this->setting_serv->insert($data);
                Log::record("add task: {$crId}", Log::INFO);
            }
        }

        return true;
    }

    /**
     * 卸载人员缓存更新
     *
     * @return bool
     */
    protected function userCacheCronDelete()
    {
        // 考试统计查询条件
        $conds['key'] = 'exam_user_cache';
        $setting = $this->setting_serv->get_by_conds($conds);

        $crId = $setting['value'];
        // 判断计划任务标识是否存在
        if (!empty($crId)) {

            $cronSdk = new Cron(Service::instance());
            $cronSdk->delete($crId);
            Log::record("delete task: {$crId}", Log::INFO);
            // 删除定时任务
            $this->setting_serv->delete($setting['id']);
        }

        return true;
    }

    /**
     * 应用数据库数据更新升级【v1.0.2】
     *
     * @author houyingcai
     *
     * @return void
     */
    protected function UpdateDB()
    {

        set_time_limit(0);
        ini_set("memory_limit", "1128M");

        try {
            $this->answer_serv->start_trans();

            // 同步last_time字段（last_time为新增加的字段）
            $this->answer_serv->execute("UPDATE oa_exam_paper set `last_time`=if(`updated` = 0,`created`,`updated`)");

            // 更新已经交卷的
            $answer_sql = 'select * from oa_exam_answer where my_time>0';
            $data = $this->answer_serv->query($answer_sql);

            $data_exist = [];
            foreach ($data as $key => $value) {
                $this->answer_one($value);
                $data_exist[] = $value['ea_id'];
            }
            // 处理 题目类型，做答状态，语音格式化，批阅状态
            $answer_detail_sql = 'select * from oa_exam_answer_detail';
            $data_two = $this->answer_serv->query($answer_detail_sql);

            if ($data_two) {
                foreach ($data_two as $key => $value) {
                    $this->answer_detail_one($value, $data_exist);
                }
            }

            $this->answer_serv->commit();

        } catch (\Think\Exception $e) {
            \Think\Log::record($e);
            // 事务回滚
            E($e->getMessage(), $e->getCode());
            $this->answer_serv->rollback();

            exit('ERROR');
        } catch (\Exception $e) {

            \Think\Log::record($e);
            E($e->getMessage(), $e->getCode());
            // 事务回滚
            $this->answer_serv->rollback();

            exit('ERROR');
        }

        exit('SUCCESS');
    }

    protected function answer_one($data)
    {
        //考试结束时间
        $my_end_time = $data['my_time'] + $data['my_begin_time'];

        $sql = "UPDATE oa_exam_answer SET answer_status = '3',my_end_time= '{$my_end_time}',marking_time='{$my_end_time}' WHERE ea_id = '{$data['ea_id']}'";

        $this->answer_serv->execute($sql);
    }

    protected function answer_detail_one($data, $data_exist)
    {

        $et_detail = unserialize($data['et_detail']);

        $is_pass = $data['is_pass'];
        // 如果有答案表示已做答
        if (!empty($data['my_answer'])) {
            // 已经作答
            $is_status = 1;
        } else {
            // 没有作答
            $is_status = 0;
        }

        $my_answer = $data['my_answer'];
        //如果语音题
        if ($et_detail['et_type'] == 5) {
            $answer = $data['my_answer'];
            $arr = array_unique(explode(',', $answer));

            $answerlist = [];
            foreach ($arr as $key => $value) {
                $answerlist[] = [
                    'type' => 1,
                    'opt' => $value
                ];
            }
            $my_answer = serialize($answerlist);
        }

        $marking_status = 0;
        if (in_array($data['ea_id'], $data_exist)) {

            $marking_status = 1;
        }

        if ($is_pass != 1) {

            $is_pass = 2;
        }

        //考试结束时间
        $sql = "UPDATE oa_exam_answer_detail SET is_pass='{$is_pass}' ,et_type = '{$et_detail['et_type']}',is_status='{$is_status}',marking_status='{$marking_status}', my_answer ='{$my_answer}' WHERE ead_id = '{$data['ead_id']}'";

        $this->answer_serv->execute($sql);
    }

    /**
     * 应用数据库数据更新升级【v2.0.2】
     *
     * @author caijianhua
     *
     * @return void
     */
    protected function UpdateDBv2()
    {
        set_time_limit(0);
        ini_set("memory_limit", "1128M");
        $sql = [];
        // 试卷表
        $pes = $this->answer_serv->query("SHOW FIELDS FROM  oa_exam_paper ");
        $field = array_column($pes, 'field');
        if (!in_array('is_old', $field)) {
            $sql[] = "ALTER TABLE oa_exam_paper add is_old TINYINT(1) UNSIGNED NOT NULL DEFAULT '1' COMMENT '数据类型 ：1旧数据 2新数据';";
        }
        // 更新答卷详情表
        $pes = $this->answer_serv->query("SHOW FIELDS FROM  oa_exam_answer_detail ");
        $field = array_column($pes, 'field');
        if (!in_array('ep_id', $field)) {
            $sql[] = "ALTER TABLE `oa_exam_answer_detail` ADD `ep_id` INT(11) NOT NULL DEFAULT '0' COMMENT '试卷ID' ;";
        }
        if (!in_array('et_id', $field)) {
            $sql[] = "ALTER TABLE `oa_exam_answer_detail` ADD `et_id` INT(11) NOT NULL DEFAULT '0' COMMENT '题目ID' ;";
        }
        if (!in_array('esr_id', $field)) {
            $sql[] = "ALTER TABLE `oa_exam_answer_detail` ADD `esr_id` INT(11) NOT NULL DEFAULT '0' COMMENT '随机题库ID或者oa_exam_snapshot表的主键' ;";
        }
        if (!in_array('paper_type', $field)) {
            $sql[] = "ALTER TABLE `oa_exam_answer_detail` ADD `paper_type` TINYINT(1) NOT NULL DEFAULT '0' COMMENT '试卷使用类型(0:测评试卷，1：模拟试卷)' ;";
        }
        if (!in_array('cron_status', $field)) {
            $sql[] = "ALTER TABLE `oa_exam_answer_detail` ADD `cron_status` TINYINT(1) NOT NULL DEFAULT '0' COMMENT '试卷使用类型(0:测评试卷，1：模拟试卷)' ;";
        }
        $pes = $this->answer_serv->query("SHOW INDEX FROM  oa_exam_answer_detail ");
        $field = array_column($pes, 'key_name');
        if (!in_array('ep_id', $field)) {
            $sql[] = "ALTER TABLE  `oa_exam_answer_detail` ADD INDEX (  `ep_id` );";
        }
        if (!in_array('et_id', $field)) {
            $sql[] = "ALTER TABLE  `oa_exam_answer_detail` ADD INDEX (  `et_id` );";
        }
        if (!in_array('paper_type', $field)) {
            $sql[] = "ALTER TABLE  `oa_exam_answer_detail` ADD INDEX (  `paper_type` );";
        }
        if (!in_array('et_type', $field)) {
            $sql[] = "ALTER TABLE  `oa_exam_answer_detail` ADD INDEX (  `et_type` );";
        }
        if (!in_array('is_pass', $field)) {
            $sql[] = "ALTER TABLE  `oa_exam_answer_detail` ADD INDEX (  `is_pass` );";
        }
        if (!in_array('esr_id', $field)) {
            $sql[] = "ALTER TABLE  `oa_exam_answer_detail` ADD INDEX (  `esr_id` );";
        }
        if (!empty($sql)) {
            foreach ($sql as $key => $value) {
                $this->answer_serv->execute($value);
            }
        }
        exit('SUCCESS');
    }

    /**
     * 定时任务列表查看
     *
     * @return void
     */
    public function CronList(){
        set_time_limit(0);
        ini_set("memory_limit", "1128M");

        $page = I('get.page');
        $limit = I('get.limit');
        $cron_serv = new Cron(Service::instance());

        $list = $cron_serv->listAll([], $page, $limit);

        print_r($list);

        exit('SUCCESS');
    }

    /**
     * 定时任务删除
     *
     * @return void
     */
    public function CronDelete(){
        set_time_limit(0);
        ini_set("memory_limit", "1128M");

        $crId = I('get.crId');

        $cron_serv = new Cron(Service::instance());

        $cron_serv->delete($crId);

        $res = $cron_serv->get($crId);

        print_r($res);

        exit('SUCCESS');
    }

    /**
     * 定时任务查看
     *
     * @return void
     */
    public function CronDetail(){
        set_time_limit(0);
        ini_set("memory_limit", "1128M");

        $crId = I('get.crId');

        $cron_serv = new Cron(Service::instance());

        $res = $cron_serv->get($crId);

        print_r($res);

        exit('SUCCESS');
    }

    /**
     * 定时任务循环间隔更新
     *
     * @return void
     */
    public function UpdateCron(){
        set_time_limit(0);
        ini_set("memory_limit", "1128M");

        // 需要修改的是：paper表的cron_stop与cron_exam
        $cron_serv = new Cron(Service::instance());

        $paper_serv = new PaperService();
        $list = $paper_serv->list_all();

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

            $crId = $v['corn_exam'];

            if(!empty($crId)){
                $params = [
                    'crId' => $crId,
                    'crCron' => '0 0/10 * * * ?'
                ];

                $res = $cron_serv->update($params);

                print_r($res);

            }

            $crId = $v['corn_stop'];

            if(!empty($crId)){
                $params = [
                    'crId' => $crId,
                    'crCron' => '0 0/10 * * * ?'
                ];

                $res = $cron_serv->update($params);

                print_r($res);

            }

        }

        exit('SUCCESS');
    }


    /**
     * 应用数据库数据更新升级【v3.0.0】
     *
     * @author daijun
     *
     * @return void
     */
    public function UpdateDBv3()
    {
        set_time_limit(0);
        ini_set("memory_limit", "1128M");
        $sql = [];
        // 调研基础信息表
        $pes = $this->answer_serv->query("SHOW FIELDS FROM  oa_exam_paper ");
        $field = array_column($pes, 'field');
        if (!in_array('integral_action_type', $field)) {
            // 新增策略类型字段
            $sql[] = "ALTER TABLE oa_exam_paper add integral_action_type TINYINT(3) UNSIGNED NOT NULL DEFAULT '1' COMMENT '积分策略(1:启用默认，2：不启用，3：启用自定义策略)'";
        }
        if (!in_array('integral_strategyid', $field)) {
            // 新增策略id字段
            $sql[] = "ALTER TABLE oa_exam_paper add integral_strategyid varchar(255) NOT NULL DEFAULT '' COMMENT '积分策略ID集合（逗号分隔）'";
        }

        $pes_a = $this->answer_serv->query("SHOW FIELDS FROM  oa_exam_answer ");
        $field_a = array_column($pes_a, 'field');
        if (!in_array('buinessid', $field_a)) {
            // 新增积分策略业务id字段
            $sql[] = "ALTER TABLE oa_exam_answer add businessid varchar(100) NOT NULL DEFAULT '' COMMENT '积分策略业务ID' AFTER `status` ";
        }

        // 新增用户参加考试通过次数统计表
        $sql[] = "CREATE TABLE IF NOT EXISTS `oa_exam_count` (
                  `id` INT(10) UNSIGNED NOT NULL AUTO_INCREMENT COMMENT '主键',
                  `uid` CHAR(32) NOT NULL DEFAULT '' COMMENT '用户ID',
                  `num` INT(10) NOT NULL DEFAULT '0' COMMENT '通过次数',
                  `paper_type` TINYINT(1) UNSIGNED NOT NULL DEFAULT '0' COMMENT '考试类型(0:测评，1：模拟)',
                  `domain` VARCHAR(32) NOT NULL DEFAULT '' COMMENT '企业域名',
                  `status` TINYINT(3) NOT NULL DEFAULT '1' COMMENT '状态=1.初始化，2.更新，3删除',
                  `created` BIGINT(13) NOT NULL DEFAULT '0' COMMENT '创建时间',
                  `updated` BIGINT(13) NOT NULL DEFAULT '0' COMMENT '更新时间',
                  `deleted` BIGINT(13) NOT NULL DEFAULT '0' COMMENT '删除时间',
                  PRIMARY KEY (`id`),
                  KEY `domain_status` (`domain`,`status`)
                ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='用户参加考试通过次数统计表';";


        if (!empty($sql)) {
            // 循环执行sql更新语句
            foreach ($sql as $key => $value) {
                $this->answer_serv->execute($value);
            }
        }

        exit('SUCCESS');
    }

}