0,'B'=>1,'C'=>2,'D'=>3,'E'=>4,'F'=>5); public $flag = 1; // 解析返回的图片是否上传ucloud 0否 1是 public $mathSubject = array(3,6,51); public function init() { @ini_set('memory_limit', '512M'); set_time_limit(0); //$this->ucloud = new Ucloud(); $this->ucloud = new Qcloud(); $this->webSiteUrl = Yii::app()->params['teacherSiteurl']; $this->flag = isset($_GET['flag']) ? intval($_GET['flag']) : 1; } /** * 全学科第三方试卷解析 * @param $string * @return mixed */ public function actionAllSubjectCoach() { $apiTopics = array(); // 获取curl过来值 $word_id = isset($_GET['wid']) ? intval($_GET['wid']) : 0; $school_id = isset($_GET['sid']) ? intval($_GET['sid']) : 0; if (empty($word_id) || empty($school_id)) { exit('未找到word Id或者学校id'); } // 连接业务库 $busDsn = Yii::app()->businessDb; $dataBaseInfo = $busDsn->createCommand('SELECT * FROM `database` WHERE `school_id`=' . $school_id)->queryRow(); if (empty($dataBaseInfo)) { exit('未找到数据库链接信息!'); } $busdbh = null; // 连接学校库 $schDsn = 'mysql:host=' . $dataBaseInfo['database_host'] . ';dbname=' . $dataBaseInfo['database_name'] . ';'; $schdbh = new PDO($schDsn, $dataBaseInfo['database_user'], $dataBaseInfo['database_password'], array(PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES "utf8";')); $wordInfo = $schdbh->query('SELECT `word_id`,`word_name`,`subject_id`,`uploader_id`,`exam_group_id` FROM `topic_word` WHERE `word_id`=' . $word_id)->fetch(PDO::FETCH_ASSOC); if (empty($wordInfo)) { exit('未找到上传word信息!'); } $getWordJson = file_get_contents('php://input'); $jsonArray = json_decode($getWordJson, true); if (empty($jsonArray) || $jsonArray['errcode'] == 1 || empty($jsonArray['items'])) { $errMsg = array(); if (isset($jsonArray['errmsgs']) && $jsonArray['errmsgs']) { if (is_array($jsonArray['errmsgs'])) { foreach ($jsonArray['errmsgs'] as $msg) { $errMsg[] = key($msg) . ':' . implode(', ', $msg[key($msg)]); } } else { $errMsg[] = $jsonArray['errmsgs']; } } $errMsg = $errMsg ? implode('
', $errMsg) : '解析异常'; $stmt = $schdbh->prepare('UPDATE `topic_word` SET `status` = 3,`wrong_reason` = :reason,`content` = :content,`file_path` = :path,parse_time=:time WHERE `word_id` =:wid'); $stmt->execute(array(':wid' => $word_id, ':reason' => $errMsg, ':content' => $getWordJson, ':path' => '', ':time' => time())); exit('解析失败!'); } else { // 获取科目题型 $tempTypeName = array(1=>'选择题','2'=>'多选题',11=>'多选题',5=>'填空题',7=>'解答题'); $apiParam = Yii::app()->params['api'][0]; $apiParam['prefix'] .= 'all_subject/topic_type/subjectId/' . $wordInfo['subject_id']; $topicTypeJson = self::getApiData($apiParam, 1, '', 3); $topicTypes = json_decode($topicTypeJson, true); if (isset($topicTypes['status'])) { if ($topicTypes['status'] == 0 || empty($topicTypes['data'])) { $stmt = $schdbh->prepare('UPDATE `topic_word` SET `status` = 3,`wrong_reason` = :reason, parse_time=:time WHERE `word_id` =:wid'); $stmt->execute(array(':wid' => $word_id, ':reason' => '未找到科目题型', ':time' => time())); exit('未找到科目题型'); } elseif ($topicTypes['status'] == 1 && $topicTypes['data']) { $topicTypes = $topicTypes['data']; } } // 查询考试试题 $paper_topic_relation_data = $schdbh->query('select pt.topic_id,pt.type,pp.* from paper_topic_relation pt join (select p.paper_id ,e.subject_id as subject_id,e.exam_group_id from exam e left JOIN paper p on e.exam_id = p.exam_id where e.exam_group_id = ' . $wordInfo['exam_group_id'] . ' GROUP BY e.exam_group_id) as pp on pt.paper_id = pp.paper_id order by pt.order asc')->fetchAll(PDO::FETCH_ASSOC); if (empty($paper_topic_relation_data)) { $stmt = $schdbh->prepare('UPDATE `topic_word` SET `status` = 3,`wrong_reason` = :reason,`content` = :content,parse_time=:time WHERE `word_id` =:wid'); $stmt->execute(array(':wid' => $word_id, ':reason' => '未找到考试试题', ':content' => $getWordJson, ':time' => time())); exit('未找到考试试题'); } if (count($paper_topic_relation_data) != count($jsonArray['items'])) { $stmt = $schdbh->prepare('UPDATE `topic_word` SET `status`=3,`wrong_reason`=:reason,`content`=:content,parse_time=:time WHERE `word_id`=:wid'); $stmt->execute(array(':wid' => $word_id, ':reason' => 'WORD题量与试卷题量不同', ':content' => $getWordJson, ':time' => time())); exit('WORD题量与试卷题量不同'); } $relate_topic_id = array(); $p_topic_type_num = array(); $relate_topic_type = array(); foreach ($paper_topic_relation_data as $v) { $relate_topic_id[] = $v['topic_id']; $p_topic_type_num[$v['type']][] = $v['topic_id']; if (!in_array($v['type'], $relate_topic_type)) { $relate_topic_type[] = $v['type']; } } // 题型格式 $topicTypeName = array(); $topicTypeConfig = array(); foreach ($topicTypes as $topicType) { $topicTypeName[$topicType['topic_type_name']] = $topicType['topic_type_id']; $topicTypeConfig[$topicType['topic_type_id']] = $topicType; } // 删除已存在试题缓存 $apiParam = Yii::app()->params['api'][0]; $apiParam['prefix'] .= 'topic_clear_redis/ctopic'; self::getApiData($apiParam, 2, json_encode(array('topicIds' => $relate_topic_id)), 3); $topic_type_num = array(); // 解析结果各题型数量 $topic_type_error = array(); // 验证是否存在非题库题型 $parse_topic_type = array(); // 解析返回的题型ID $topic_type_name = array(); $bankTypeParam = Yii::app()->params['subject_topic_type_matching']; // 全学科基本题型与老题库对应 foreach ($jsonArray['items'] as $loop) { if (!isset($topicTypeName[$loop['type']])) { $topic_type_error[] = "题库不存在【{$loop['type']}】题型不存在"; } else { $tempTypeId = (int)$topicTypeName[$loop['type']]; $typeConfig = $topicTypeConfig[$tempTypeId]; if (isset($bankTypeParam[$typeConfig['btt_id']])) { if (!isset($topic_type_num[$bankTypeParam[$typeConfig['btt_id']]])) { $parse_topic_type[] = $bankTypeParam[$typeConfig['btt_id']]; $topic_type_num[$bankTypeParam[$typeConfig['btt_id']]] = array(); } $topic_type_num[$bankTypeParam[$typeConfig['btt_id']]][] = 1; } } } if ($topic_type_error) { $stmt = $schdbh->prepare('UPDATE `topic_word` SET `status` = 3,`wrong_reason` = :reason,`content` = :content, parse_time=:time WHERE `word_id` =:wid'); $stmt->execute(array(':wid' => $word_id, ':reason' => implode('
', $topic_type_error), ':content' => $getWordJson, ':time' => time())); exit('题型不存在'); } // 获取默认文件夹id $defaultFolder = $schdbh->query('SELECT `folder_id` FROM `topic_folder` WHERE `is_system`=1')->fetch(PDO::FETCH_ASSOC); $folderId = empty($defaultFolder['folder_id']) ? 0 : $defaultFolder['folder_id']; // 解析试题内容 foreach ($jsonArray['items'] as $key => $item) { $topicId = $paper_topic_relation_data[$key]['topic_id']; $apiTopics[] = $topicId; $typeId = (int)$topicTypeName[$item['type']]; $typeConfig = $topicTypeConfig[$typeId]; // 试题入库处理 try { $schdbh->beginTransaction(); // 开启事务 $now_time = time(); $difficulty = isset($item['difficulty']) ? $item['difficulty'] : 1; // topic表 $stmt = $schdbh->prepare('UPDATE `topic` SET `topic_title` = :topic_title,`topic_difficulty` = :topic_difficulty,`source_title`=:source_title,`bank_type`=:bank_type,`parse_content`=:parse_content,`update_time`=:update_time WHERE `topic_id` =:topic_id'); $stmt->execute(array(':topic_id' => $topicId, ':topic_title' => $item['stem'],':topic_difficulty'=>$difficulty,':bank_type'=>$typeId, ':source_title' => 'word上传试题', ':parse_content' => $item['analysis'], ':update_time' => time())); // topic_item $stmt = $schdbh->prepare('UPDATE `topic_item` SET `topic_title` = :topic_title WHERE `topic_id` =:topic_id'); $stmt->execute(array(':topic_id' => $topicId, ':topic_title' => $item['stem'])); $stmt = $schdbh->prepare('delete from `topic_item_option` WHERE `topic_id` =:topic_id'); $stmt->execute(array(':topic_id' => $topicId)); // 选择题选项处理 if (isset($item['options']) && $item['options']) { // 含有选项的试题 //$optionKeys = explode(',', $item['key']); $optionKeys = array(); foreach ($this->charToNum as $char => $num) { if (strpos($item['key'], $char) !== false) { $optionKeys[] = $char; } } $rowThr = $schdbh->prepare('INSERT INTO `topic_item_option`(`topic_id`, `option_content`, `option_correct`,`sort_order`) VALUES (:tpid,:content,:correct,:sort_order)'); $correct = 'A'; foreach ($item['options'] as $vk => $option) { $is_true = in_array($correct, $optionKeys) ? 1 : 0; $getRowThr = $rowThr->execute(array(':tpid'=>$topicId,':content'=>$option,':correct'=>$is_true,':sort_order'=>$vk)); ++$correct; } } else { $rowFiv = $schdbh->prepare('INSERT INTO `topic_item_option`(`topic_id`, `option_content`) VALUES (:tpid,:content)'); if (is_array($item['key']) && $item['key']) { foreach ($item['key'] as $topicKey) { $getRowFiv = $rowFiv->execute(array(':tpid' => $topicId, ':content' => $topicKey)); } } else { $getRowFiv = $rowFiv->execute(array(':tpid' => $topicId, ':content' => $item['key'])); if (!$getRowFiv) { throw new PDOException('插入topic_item_option表失败!'); } } } // word与试题关系 $rowFor = null; $rowFor = $schdbh->prepare('INSERT INTO `word_topic_relation`(`word_id`, `topic_id`) VALUES (:wid,:toid)'); $getRowFor = $rowFor->execute(array(':wid' => $word_id, ':toid' => $topicId)); if (!$getRowFor) { throw new PDOException('插入word_to_topic表失败!'); } $schdbh->commit(); } catch (PDOException $e) { $schdbh->rollback(); // 执行失败,事务回滚 $stmt = $schdbh->prepare('UPDATE `topic_word` SET `status` = 3,`wrong_reason` = :reason,`content` = :content,parse_time=:time WHERE `word_id` =:wid'); $stmt->execute(array(':wid' => $word_id, ':reason' => $e->getMessage(), ':content' => $getWordJson, ':time' => time())); exit($e->getMessage()); } } //exit($topicId); } // 处理完 $resu = $schdbh->prepare('UPDATE `topic_word` SET `status` = 2,`parse_time`=:time,`content` = :content WHERE `word_id` =:wid'); $resu->execute(array(':wid' => $word_id, ':time' => time(), ':content' => $getWordJson)); $resu = $schdbh->prepare('UPDATE `exam_group` SET `is_answersheet` = 1 WHERE `exam_group_id` =:exam_group_id'); $resu->execute(array(':exam_group_id' => $wordInfo['exam_group_id'])); // 插入解析时间记录 $resPro = $schdbh->prepare("INSERT INTO `exam_process` (`exam_group_id`, `action_type`, `action_time`) VALUES (:exam_group_id, :tempType, :time)"); $resPro->execute(array(':exam_group_id' => $wordInfo['exam_group_id'], ':tempType' => 4, ':time' => time())); $schdbh = null; if($apiTopics){ //调用试题检索接口 $this->searchTopics($apiTopics,$school_id); } exit('解析完成!'); } // 试题内容相关过滤处理等 function strip_content_tags($str) { if (empty($str)) return $str; $allow_tags = "