view->config = Zend_Registry::get('config'); $this->db=Zend_Registry::get('db'); $this->messenger=$this->_helper->getHelper('FlashMessenger'); $this->view->messages = $this->messenger->getMessages(); } function indexAction() { } /* * helpAction() 帮助文档 * */ function helpAction(){ }//helpAction()帮助文档 /* * inauthorAction() 数据申请管理 * * param string $ac * param string $keywords * param string $pr //对离线数据申请的操作 * param string $uuid * * return view|ajax-responds */ function inauthorAction() { $ac = $this->_request->getParam("ac"); $auth = Zend_Auth::getInstance(); if($auth->hasIdentity()) { $user = $auth->getIdentity(); $u_id = $user->id; $u_email = $user->email; } if(empty($ac) || $ac=="online" || $ac == "searchonline") { $sql = "SELECT o.id,o.userid,o.unit,o.username,o.ts_created,o.project,m.title,m.uuid FROM onlineapp as o LEFT JOIN metadata as m ON o.uuid=m.uuid LEFT JOIN mdauthor as a ON a.uuid=o.uuid WHERE (o.id in (SELECT distinct(onlineappid) from dataorder where status>=0)) AND a.userid = ? AND a.status=1"; if ($ac=="searchonline") { $keywords = $this->_request->getParam('q'); if(!empty($keywords)) $this->view->q = $keywords; $search=new Search($keywords); $where=$search->sql_expr(array("m.title","m.description")); $sql.=' and '.$where; } $sql.=" ORDER BY o.id desc"; $sth = $this->db->prepare($sql); $sth->execute(array($u_id)); $rows = $sth->fetchAll(); $paginator = Zend_Paginator::factory($rows); $paginator->setCurrentPageNumber($this->_getParam('page')); $paginator->setItemCountPerPage(10); $paginator->setView($this->view); Zend_View_Helper_PaginationControl::setDefaultViewPartial('pagination_param.phtml'); $this->view->paginator=$paginator; }//在线申请记录 if($ac == "offline" || $ac=="searchoffline") { $pr = $this->_request->getParam('pr'); $oid = $this->_request->getParam('oid'); $pdf = $this->_request->getParam('pdf'); if(!empty($pr)) { try{ $this->_helper->layout->disableLayout(); $this->_helper->viewRenderer->setNoRender(); $uuid = $this->_request->getParam('uuid'); if(!preg_match("/^[0-9A-Za-z]{8}-[0-9A-Za-z]{4}-[0-9A-Za-z]{4}-[0-9A-Za-z]{4}-[0-9A-Za-z]{12}$/",$uuid)) { echo "参数有误!";exit(); } //如果用户已经下载过了,就无法在更改对数据申请的意见 $sql = "select md.title,d.uuid,d.status as datastatus,d.authorpermitted from dataorder d left join offlineapp o on o.id=d.offlineappid left join metadata md on md.uuid=d.uuid left join mdauthor a on a.uuid=d.uuid where o.ts_approved is null and o.pdflink is not null and d.uuid=? and a.userid=? and d.id=? AND a.status=1 order by o.ts_created desc"; $sth = $this->db->prepare($sql); $sth->execute(array($uuid,$u_id,$oid)); $row = $sth->fetch(); if($row['datastatus']>4) { echo "该申请已经通过并且发放数据"; exit(); } else if (empty($row) || $row['datastatus']!=4) { echo "该数据申请存在问题,请联系数据中心!"; exit(); } //同意用户下载 if($pr=="confirm") { $sql = "UPDATE dataorder SET authorpermitted=1 WHERE uuid=? and id=?"; $sth = $this->db->prepare($sql); if($sth->execute(array($uuid,$oid))) { $btn = $this->createOfflineCtBtn($uuid,'c',$oid); echo ''.$btn.''; exit(); }else{ echo ""; exit(); } } //反对用户下载 if($pr == "objection") { $sql = "UPDATE dataorder SET authorpermitted=-1 WHERE uuid=? AND id=?"; $sth = $this->db->prepare($sql); if($sth->execute(array($uuid,$oid))) { $btn = $this->createOfflineCtBtn($uuid,'o',$oid); echo ''.$btn.''; exit(); }else{ echo ""; exit(); } } }catch(Exception $e) { echo "处理中遇到错误,请刷新页面后重试"; exit(); } } else if (!empty($pdf)) { $sql="select o.pdflink from dataorder d left join offlineapp o on d.offlineappid=o.id left join mdauthor m on d.uuid=m.uuid where d.id=? and m.userid=?"; $sth = $this->db->prepare($sql); $sth->execute(array($pdf,$u_id)); $row = $sth->fetch(); $content=file_get_contents($this->view->config->offline->savepath."/".$row['pdflink']); header("Content-Disposition: inline; filename=".$row['pdflink']); header("Content-Type:application/pdf"); echo $content; die(); // do not change current html output } else { $this->_helper->viewRenderer('inauthor-offline'); $select="select distinct(o.*),md.title,d.id as doid,d.uuid,d.status as datastatus,d.authorpermitted from offlineapp o left join dataorder d on o.id=d.offlineappid left join metadata md on md.uuid=d.uuid left join mdauthor a on a.uuid=d.uuid where o.ts_approved is null and o.pdflink is not null and d.status=4 and a.userid=? AND a.status=1 "; if($ac == "searchoffline") { $keywords = $this->_request->getParam('q'); if(!empty($keywords)) $this->view->q = $keywords; $search=new Search($keywords); $where=$search->sql_expr(array("md.title","md.description")); $select.=' and '.$where; } $select.=" order by o.ts_created desc"; $sth = $this->db->prepare($select); $sth->execute(array($u_id)); $rows = $sth->fetchAll(); foreach ($rows as $k=>$v) { if($v['authorpermitted']==0) {$rows[$k]['btns']=$this->createOfflineCtBtn($v['uuid'],'',$v['doid']);} if($v['authorpermitted']>0) {$rows[$k]['btns']=$this->createOfflineCtBtn($v['uuid'],'c',$v['doid']);} if($v['authorpermitted']<0) {$rows[$k]['btns']=$this->createOfflineCtBtn($v['uuid'],'o',$v['doid']);} } $paginator = Zend_Paginator::factory($rows); $paginator->setCurrentPageNumber($this->_getParam('page')); $paginator->setItemCountPerPage(10); $paginator->setView($this->view); Zend_View_Helper_PaginationControl::setDefaultViewPartial('pagination_param.phtml'); $this->view->paginator=$paginator; } }//离线申请 //按数据显示 if($ac == 'datalist' || $ac == "searchdata") { $uuid = $this->_request->getParam('uuid'); if(!empty($uuid)) { $this->_helper->viewRenderer('view-dataoreder'); if(preg_match("/^[0-9A-Za-z]{8}-[0-9A-Za-z]{4}-[0-9A-Za-z]{4}-[0-9A-Za-z]{4}-[0-9A-Za-z]{12}$/",$uuid)) { $sql = "select md.title,d.id as doid,d.uuid,d.authorpermitted,d.status ,offa.id as offa_id,offa.username as offa_name,offa.unit as offa_unit,offa.email as offa_email,offa.project as offa_project ,ona.id as ona_id,ona.username as ona_name,ona.unit as ona_unit,ona.email as ona_email,ona.project as ona_project from dataorder d left join metadata md on md.uuid=d.uuid left join mdauthor a on a.uuid=d.uuid LEFT JOIN offlineapp offa on offa.id=d.offlineappid LEFT JOIN onlineapp ona on ona.id=d.onlineappid WHERE (offa.id IS NOT NULL OR ona.id IS NOT NULL) AND a.status=1 and d.status>=0 AND d.uuid=? AND a.userid=? ORDER BY d.ts_created DESC"; $sth = $this->db->prepare($sql); $sth->execute(array($uuid,$u_id)); $rows = $sth->fetchAll(); @$this->view->mdtitle=$rows[0]['title']; foreach ($rows as $k=>$v) { if($v['authorpermitted']==0) {$rows[$k]['btns']=$this->createOfflineCtBtn($v['uuid'],'',$v['doid']);} if($v['authorpermitted']>0) {$rows[$k]['btns']=$this->createOfflineCtBtn($v['uuid'],'c',$v['doid']);} if($v['authorpermitted']<0) {$rows[$k]['btns']=$this->createOfflineCtBtn($v['uuid'],'o',$v['doid']);} } $paginator = Zend_Paginator::factory($rows); $paginator->setCurrentPageNumber($this->_getParam('page')); $paginator->setItemCountPerPage(10); $paginator->setView($this->view); Zend_View_Helper_PaginationControl::setDefaultViewPartial('pagination_param.phtml'); $this->view->paginator=$paginator; }else{ $this->view->error = "参数有误"; } }else{ $this->_helper->viewRenderer('inauthor-datalist'); $sql = "select md.title,d.uuid,count(md.id) as c from dataorder d left join metadata md on md.uuid=d.uuid left join mdauthor a on a.uuid=d.uuid where a.status=1 AND a.userid=? "; if($ac == "searchdata") { $keywords = $this->_request->getParam('q'); if(!empty($keywords)) $this->view->q = $keywords; $search=new Search($keywords); $where=$search->sql_expr(array("md.title","md.description")); $sql.=' and '.$where; } $sql.=" GROUP BY md.title,d.uuid"; $sth = $this->db->prepare($sql); $sth->execute(array($u_id)); $rows = $sth->fetchAll(); $paginator = Zend_Paginator::factory($rows); $paginator->setCurrentPageNumber($this->_getParam('page')); $paginator->setItemCountPerPage(10); $paginator->setView($this->view); Zend_View_Helper_PaginationControl::setDefaultViewPartial('pagination_param.phtml'); $this->view->paginator=$paginator; } }//按数据显示 } // inauthorAction() 数据申请管理 /* * createOfflineCtBtn() 创建离线申请记录的操作按钮 * */ function createOfflineCtBtn($uuid, $type="",$oid){ $urlHref = 'href="javascript:;"'; $baseStyle = "offline-ct-btns box-shadow"; $selectedStyle = "offline-select"; $confrimText = "同意"; $confrimFunc = 'onclick="confirm(\''.$uuid.'\',\''.$oid.'\')"'; $objectionText = "反对"; $objectionFunc = 'onclick="objection(\''.$uuid.'\',\''.$oid.'\')"'; $btns=''; if(empty($type)) { $confrimBtn = "$confrimText"; $objectionBtn = "$objectionText"; $btns = $confrimBtn.$objectionBtn; } if($type=='c') { $confrimBtn = "$confrimText"; $objectionBtn = "$objectionText"; $btns = $confrimBtn.$objectionBtn; } if($type=='o') { $confrimBtn = "$confrimText"; $objectionBtn = "$objectionText"; $btns = $confrimBtn.$objectionBtn; } return $btns; } //createOfflineCtBtn() /* * acceptAction() 我的数据 * * param string $ac // list|search * param string $keyword * * return view */ function acceptAction() { $ac = $this->_request->getParam("ac"); $auth = Zend_Auth::getInstance(); if($auth->hasIdentity()) { $user = $auth->getIdentity(); $u_id = $user->id; $u_email = $user->email; } //列表 if(empty($ac) || $ac=='list' || $ac=='search'){ $sql = "SELECT a.*,m.title,m.description,g.id as gid FROM normalmetadata m LEFT JOIN mdauthor a ON m.uuid=a.uuid left join geonetworkmetadata g on m.uuid=g.uuid WHERE a.userid=? AND status>=0"; if ($ac=='search') { $key = trim($this->_request->getParam('q')); $this->view->q = $key; $search=new Search($key); $where=$search->sql_expr(array("m.title","m.description")); $sql.=' and '.$where; } $sql.="ORDER BY status DESC,a.id DESC"; $sth = $this->db->prepare($sql); $sth->execute(array($u_id)); $rows = $sth->fetchAll(); $paginator = Zend_Paginator::factory($rows); $paginator->setCurrentPageNumber($this->_getParam('page')); $paginator->setItemCountPerPage(5); $paginator->setView($this->view); Zend_View_Helper_PaginationControl::setDefaultViewPartial('pagination_param.phtml'); $this->view->paginator=$paginator; }//list //激活数据作者 if($ac == "active") { $this->_helper->viewRenderer('accept-active'); $vdcode = $this->_request->getParam('v'); $this->view->v = $vdcode; try{ $sql = "SELECT a.id,a.activation,a.ts_created,a.ts_activated,md.title,a.uuid,u.id as userid,u.realname,u.email FROM mdauthor a LEFT JOIN metadata md ON a.uuid=md.uuid LEFT JOIN users u ON a.userid=u.id WHERE a.activation=?"; $sth = $this->db->prepare($sql); $sth->execute(array($vdcode)); $row = $sth->fetch(); if(empty($row['id'])) { $this->view->info='此激活码无效'; }else{ if(empty($row['ts_activated'])) { $sql = "UPDATE mdauthor SET ts_activated=?,status=? WHERE activation=?"; $sth = $this->db->prepare($sql); $ex = $sth->execute(array('now()',1,$vdcode)); if($ex) { include_once("EmailText.php"); $this->author_first($row['uuid'],$row['userid']); $mail=new WestdcMailer($this->view->config->smtp); $mail->setFrom($this->view->config->service->email,'西部数据中心服务组'); $mailtp=new EmailText($this->db,"author-new",array( 'user' => $row['realname'], 'uuid' => $row['uuid'], 'title'=> $row['title'], 'email'=> $row['email'], )); $mail->setBodyText($mailtp->getBody()); $mail->setSubject($mailtp->getSubject()); if($this->debug==0) { //获得元数据作者email /* 不需要给这些人发通知邮件 $info = $this->getEmail($uuid,1); $address = $info['addrs']; foreach($address as $v) { $mail->addTo($v); }*/ $mail->addTo($row['email']); $mail->addCc($this->view->config->service->email); //管理员 }else{ $mail->addTo($this->debug_email); } $mail->send(); $this->view->info = '激活成功
点击这里进入我的数据页面查看'; }else { $this->view->info = "激活中遇到问题,请重试"; } }else { $this->view->info='此激活码已经失效'; } } }catch(Exception $e){ if($this->debug==0) { $this->view->info = "处理中遇到错误,请重新尝试"; }else{ $this->view->info = $e->getMessage(); } } }//激活数据作者 //拒绝激活 if($ac == "lock") { $this->_helper->viewRenderer('accept-active'); $vdcode = $this->_request->getParam('v'); $this->view->v = $vdcode; try{ $sql = "SELECT a.id,a.activation,a.ts_created,a.ts_activated,md.title,a.uuid,u.realname,u.email FROM mdauthor a LEFT JOIN metadata md ON a.uuid=md.uuid LEFT JOIN users u ON a.userid=u.id WHERE a.activation=?"; $sth = $this->db->prepare($sql); $sth->execute(array($vdcode)); $row = $sth->fetch(); if(empty($row['id'])) { $this->view->info='此激活码无效'; }else{ if(empty($row['ts_activated'])) { $sql = "UPDATE mdauthor SET ts_activated=?,status=? WHERE activation=?"; $sth = $this->db->prepare($sql); $ex = $sth->execute(array('now()',-1,$vdcode)); if($ex) { include_once("EmailText.php"); $mail=new WestdcMailer($this->view->config->smtp); $mail->setFrom($this->view->config->service->email,'西部数据中心服务组'); $mailtp=new EmailText($this->db,"author-deny",array( 'user' => $row['realname'], 'uuid' => $row['uuid'], 'title'=> $row['title'], 'email'=> $row['email'], )); $mail->setBodyText($mailtp->getBody()); $mail->setSubject($mailtp->getSubject()); if($this->debug==0) { $mail->addTo($row['email']); $mail->addCc($this->view->config->service->email); }else{ $mail->addTo($this->debug_email); } $mail->send(); $this->view->info = '该申请已被拒绝,点击这里进入我的数据页面查看'; }else { $this->view->info = "激活中遇到问题,请重试"; } }else { $this->view->info='此激活码已经失效'; } } }catch(Exception $e){ if($this->debug==0) { $this->view->info = "处理中遇到错误,请重新尝试"; }else{ $this->view->info = $e->getMessage(); } } }//否认激活 }//acceptAction() 我的数据 /* * * getEmail() 获取数据所有者电子邮箱地址 * * param string $uuid //UUID * param int $level //输出信息等级 * 0 => 输出所有Email地址 * 1 => 输出数据权限等级最高的Email地址 (def) * * return array() */ function getEmail($uuid,$level=1) { //需要定义角色,防止程序流程出错 $addrs = array(); $addrs['resourceProvider'] = array(); $addrs['owner'] = array(); $addrs['pointOfContact'] = array(); $addrs['author'] = array(); $addrs["publisher"] = array(); $sql = 'select r.uuid,p.email,md.title,r.role from normalmetadata md LEFT JOIN role r ON md.uuid=r.uuid left join responsible p on r.resid=p.id WHERE r.uuid=? AND p.email IS NOT NULL AND p.email!=? GROUP BY r.uuid,p.email,md.title,r.role'; $sth = $this->db->prepare($sql); $sth->execute(array($uuid,'')); $rows = $sth->fetchAll(); $addrs['title'] = $rows[0]['title']; foreach($rows as $k=>$v) { //数据资源提供者resourceProvider if($v['role']=='resourceProvider') { $addrs['resourceProvider'][]=$v['email']; } //数据资源所有者owner if($v['role']=='owner') { $addrs['owner'][]=$v['email']; } //数据联系人pointOfContact if($v['role']=='pointOfContact') { $addrs['pointOfContact'][]=$v['email']; } //元数据作者author if($v['role']== 'author' ) { $addrs['author'][] = $v['email']; } if($v["role"] =="") { $addrs["publisher"][] = $v['email']; } } //输出所有email (多维数组) /* $addrs['resourceProvider'] $addrs['owner'] $addrs['pointOfContact'] $addrs['author'] */ if($level == 0) { return $addrs; } //输出最高优先级的Email //$addrs['addrs'] if($level == 1) { //如果有 数据资源提供者 resourceProvider 就输出他的地址 以此类推 if(count($addrs['resourceProvider'])>0) { $addrs['addrs'][] = $addrs['resourceProvider']; return $addrs; } if(count($addrs['owner'])>0) { $addrs['addrs'][] = $addrs['owner']; return $addrs; } if(count($addrs['pointOfContact'])>0) { $addrs['addrs'][] = $addrs['pointOfContact']; return $addrs; } if(count($addrs['author'])>0) { $addrs['addrs'][] = $addrs['author']; return $addrs; } if(count($addrs["publisher"])>0) { $addrs['addrs'][] = $addrs["publisher"]; return $addrs; } } }//getEmail 获取数据作者email地址 /* * applyAction() 申请成为元数据作者 * * param string $ac //动作 search|apply * param string $q //搜索关键词 * param string $uuid //数据的UUID * * return view|ajax|json * * 调试搜索结果: * /author/apply?ac=apply&uuid=816ecd28-ba88-464b-a83a-341440f536ef */ function applyAction() { $ac = $this->_request->getParam('ac'); //搜索动作 if($ac == "search") { $this->_helper->layout->disableLayout(); $this->_helper->viewRenderer->setNoRender(); //要输出的Json对象 //过程中如果没有处理,则不包含任何返回信息,由前台定义提示信息,如: /* $.ajax({ 'type':"POST", 'url':'/author/apply', 'data':'ac=search&q='+$('#keyword').val(), 'success':function(data){ if (typeof(data)=='object') //如果服务器端的响应为Json对象 { if(typeof(data.error)!='undefined') //服务器端响应的错误消息 { alert(data.error); }else{ //服务器端无错误消息则为成功的响应 alert(data.length); } }else{ //服务器端响应了非JSON对象或者为空 alert('无搜索结果'); } }, 'beforeSend':function(){ //请求发送前 } }); 错误消息的键名必须为error,不包含JS脚本,如: $data['error'] = '服务器忙!'; */ $data = ""; //防止通过其它方式访问,先判断是否是登录用户,如果不是,抛出消息后强制用户退出 $auth = Zend_Auth::getInstance(); if($auth->hasIdentity()) { $user = $auth->getIdentity(); $u_id = $user->id; }else{ $data = array("error"=>"请先登录"); $this ->getResponse() ->setHeader('Content-Type', 'application/json') ->appendBody(Zend_Json::encode($data)); return true; } //数据处理代码 EOH<<<<<<<<<<<<<<<< try{ $keyword = trim($this->_request->getParam('q')); if (strlen(trim($keyword))<3) $data = array('error'=>'搜索关键字过短'); else if (!preg_match_all("/^[\x{4e00}-\x{9fa5}A-Za-z0-9\s_]+$/u",$keyword,$matchs)) { $data = array('error'=>'搜索关键字中只能包含汉字、英文、数字'); } else { //搜索标题和描述两个字段 $sql = "SELECT m.uuid,m.title,m.description,a.status,a.userid FROM normalmetadata m LEFT JOIN mdauthor a ON m.uuid=a.uuid WHERE "; $search=new Search($keyword); $where=$search->sql_expr(array("m.title","m.description")); $sql.=$where; $sth = $this->db->prepare($sql); $sth->execute(); $rows = $sth->fetchAll(); if(is_array($rows) && count($rows)>0) $data = $rows; else $data = ""; } }catch(Exception $e){ //如果上面的程序已经发送出提示,就不发送抛出的错误 if(empty($data['error'])) { if($this->debug==0) { $data = array("error"=>"处理过程中遇到错误,请重新尝试"); }else{ $data = array("error"=>$e->getMessage()); } } } // >>>>>>>>>>> F //截获响应对象,并修改头部和内容 //不管有没有数据存在,都将返回Json数据,前台有判断机制来分析数据 $this ->getResponse() ->setHeader('Content-Type', 'application/json') ->appendBody(Zend_Json::encode($data)); }// search /**************** 申请动作 ****************/ if($ac == "apply") { $this->_helper->layout->disableLayout(); $this->_helper->viewRenderer->setNoRender(); $data = ""; $auth = Zend_Auth::getInstance(); if($auth->hasIdentity()) { $user = $auth->getIdentity(); $u_id = $user->id; $u_email = $user->email; } //处理部分<<<<<<<<<< try{ $uuid = $this->_request->getParam('uuid'); if(preg_match("/^[0-9A-Za-z]{8}-[0-9A-Za-z]{4}-[0-9A-Za-z]{4}-[0-9A-Za-z]{4}-[0-9A-Za-z]{12}$/",$uuid)) { //判断该用户是否已经申请过或者是否已经是该元数据作者 $sql="SELECT id,status FROM mdauthor WHERE uuid=? AND userid=?"; $sth = $this->db->prepare($sql); $sth->execute(array($uuid,$u_id)); $row = $sth->fetch(); //如果已经是元数据作者,从流程中直接退出程序 if(!empty($row['id']) && $row['status']==1) { $data = array("error"=>"您目前已经是该数据作者,不需要再申请"); } //如果已经遭到明确拒绝,则不允许用户再次申请 if(!empty($row['id']) && $row['status']==-1) { $data = array("error"=>"您的申请已经遭到拒绝,不能再申请,有疑问请联系数据中心"); } //如果已经存在申请,但是没有激活的,返回激活信息 if($row['status']==0){ if(!empty($row['id']) && empty($m)) { $data = array( "error"=>'您已经申请过了,如果长时间没有收到回应请联系数据中心', "post"=>"activa", "uid"=>$u_id, "uemail"=>$u_email, "uuid"=>$uuid, ); }//if else{ $info = $this->getEmail($uuid,1); $address = $info['addrs']; $mdtitle = $info['title']; //如果当前用户的email包含在元数据作者email列表中,则直接使其成为元数据作者 if(in_array($u_email,$address)) { $sql = "INSERT INTO mdauthor (uuid,userid,activation,ts_activated,status) VALUES (?,?,?,?,?)"; $sth = $this->db->prepare($sql); $ex = $sth->execute(array($uuid,$u_id,'','now()',1)); if($ex) { $data = array("error"=>"您的身份符合申请条件,已经自动成为该元数据作者"); $this->author_first($uuid,$u_id); include_once("EmailText.php"); $mail=new WestdcMailer($this->view->config->smtp); $mail->setFrom($this->view->config->service->email,'西部数据中心服务组'); $mailtp=new EmailText($this->db,"author-new",array( 'user' => $user->realname, 'uuid' => $uuid, 'title'=> $mdtitle, 'email'=> $u_email, )); $mail->setBodyText($mailtp->getBody()); $mail->setSubject($mailtp->getSubject()); if($this->debug==0) { foreach ($address as $dist) {$mail->addTo($dist);} //元数据作者 $mail->addTo($u_email); $mail->addCc($this->view->config->service->email); //管理员 }else{ $mail->addTo($this->debug_email); } $mail->send(); } else { $data = array("error"=>"处理中出现错误,请重新尝试"); } } //如果不包含在当前元数据作者的email列表中 //给数据拥有者发送邮件,使其决定是否同意新加入作者 else { //生成激活码 $ssid = session_id(); $vdcode = md5($uuid.$ssid.$u_id.time()); //激活链接 // /author/accept/?ac=active&vdcode=$vdcode $sql = "INSERT INTO mdauthor (uuid,userid,activation) VALUES (?,?,?)"; $sth = $this->db->prepare($sql); $ex = $sth->execute(array($uuid,$u_id,$vdcode)); if($ex) { //给申请者发送邮件 include_once("EmailText.php"); @$mail=new WestdcMailer($this->view->config->smtp); @$mail->setFrom($this->view->config->service->email,'西部数据中心服务组'); @$mailtp=new EmailText($this->db,"author-apply",array( 'user' => $user->username, 'uuid' => $uuid, 'email'=> $user->email, //元数据标题 'title'=> $mdtitle, )); @$mail->setBodyText($mailtp->getBody()); @$mail->setSubject($mailtp->getSubject()); if($this->debug==0) { @$mail->addTo($user->email); }else{ @$mail->addTo($this->debug_email); } @$mail->send(); unset($mail); unset($mailtp); //给元数据作者以及管理员发送邮件 @$mail=new WestdcMailer($this->view->config->smtp); @$mail->setFrom($this->view->config->service->email,'西部数据中心服务组'); @$mailtp=new EmailText($this->db,"author-apply-confirm",array( 'user' => $user->username, 'uuid' => $uuid, 'email'=> $u_email, 'title'=> $mdtitle, 'link'=>"http://".$_SERVER['SERVER_NAME']."/data/$uuid", //验证码 'vdcode' => $vdcode, //激活链接 'active'=>"http://".$_SERVER['SERVER_NAME']."/author/accept/?ac=active&v=$vdcode", //不同意激活的链接 'lock'=>"http://".$_SERVER['SERVER_NAME']."/author/accept/?ac=lock&v=$vdcode", )); @$mail->setBodyText($mailtp->getBody()); @$mail->setSubject($mailtp->getSubject()); if($this->debug==0) { $sql = "SELECT u.email FROM mdauthor a LEFT JOIN users u ON u.id=a.userid WHERE a.uuid=?"; $sth = $this->db->prepare($sql); $sth->execute(array($uuid)); $mlist = $sth->fetchAll(); if(count($mlist)>0) { foreach($mlist as $v) { $mail->addTo($v['email']); } }//mdauthor中已经注册的用户 else{ foreach ($address as $dist) { $mail->addTo($dist); } }//元数据作者 $mail->addCc($this->view->config->service->email); //管理员 }else{ @$mail->addTo($this->debug_email); } @$mail->send(); $data = array("error"=>"您的申请已收到,请耐心等待回应"); }else{ $data = array("error"=>"服务器可能在忙,请重试。"); }//激活码记录 }//不是确认的元数据作者 }//empty($row['id']) }// status == 0 //调试输出结果 //$data = array('addr'=>$address,'uemail'=>$u_email); } else { $data = array('error'=>'参数出错,请按照正确的访问方式申请'); } }catch(Exception $e){ if(empty($data['error'])) { if($this->debug==0) { $data = array("error"=>"处理过程中遇到错误,请重新尝试"); }else{ $data = array("error"=>$e->getMessage()); } } } // >>>>>>>>>>>> $this ->getResponse() ->setHeader('Content-Type', 'application/json') ->appendBody(Zend_Json::encode($data)); }// ac = apply 申请处理 }//applyAction() 申请成为元数据作者 /* * commentAction() 数据反馈 * * param string $ac 动作 * param string $uuid 元数据UUID * param int $page 页数 * * return view */ function commentAction() { $ac = $this->_request->getParam('ac'); $auth = Zend_Auth::getInstance(); if($auth->hasIdentity()) { $user = $auth->getIdentity(); $u_id = $user->id; } if(empty($ac)|| $ac=='list') { $sql = "SELECT md.title,md.uuid,count(c.id) as c FROM comments c LEFT JOIN metadata md ON md.uuid=c.uuid LEFT JOIN mdauthor a ON md.uuid=a.uuid WHERE md.title IS NOT NULL AND a.userid=? AND a.status=1 GROUP BY md.title,md.uuid "; $sth = $this->db->prepare($sql); $sth->execute(array($u_id)); $rows = $sth->fetchAll(); $paginator = Zend_Paginator::factory($rows); $paginator->setCurrentPageNumber($this->_getParam('page')); $paginator->setItemCountPerPage(15); $paginator->setView($this->view); Zend_View_Helper_PaginationControl::setDefaultViewPartial('pagination_param.phtml'); $this->view->paginator=$paginator; } if($ac=="view") { $uuid = $this->_request->getParam('uuid'); if(preg_match("/^[0-9A-Za-z]{8}-[0-9A-Za-z]{4}-[0-9A-Za-z]{4}-[0-9A-Za-z]{4}-[0-9A-Za-z]{12}$/",$uuid)) { $sql = "SELECT c.author,c.email,c.url,c.ts_created,c.content,m.title FROM comments c LEFT JOIN mdauthor a ON a.uuid=c.uuid left join metadata m on m.uuid=c.uuid WHERE c.uuid=? AND a.userid=? AND a.status=1 ORDER BY ts_created DESC"; $sth = $this->db->prepare($sql); $sth->execute(array($uuid,$u_id)); $rows = $sth->fetchAll(); @$this->view->mdtitle=$rows[0]['title']; $paginator = Zend_Paginator::factory($rows); $paginator->setCurrentPageNumber($this->_getParam('page')); $paginator->setItemCountPerPage(10); $paginator->setView($this->view); Zend_View_Helper_PaginationControl::setDefaultViewPartial('pagination_param.phtml'); $this->view->paginator=$paginator; } $this->_helper->viewRenderer('comment-list'); } if($ac == "listall") { $sql = "SELECT md.title,c.author,c.email,c.url,c.ts_created,c.content FROM comments c LEFT JOIN mdauthor a ON a.uuid=c.uuid LEFT JOIN normalmetadata md ON md.uuid=c.uuid WHERE a.userid=? AND a.status=1 ORDER BY ts_created DESC"; $sth = $this->db->prepare($sql); $sth->execute(array($u_id)); $rows = $sth->fetchAll(); $paginator = Zend_Paginator::factory($rows); $paginator->setCurrentPageNumber($this->_getParam('page')); $paginator->setItemCountPerPage(10); $paginator->setView($this->view); Zend_View_Helper_PaginationControl::setDefaultViewPartial('pagination_param.phtml'); $this->view->paginator=$paginator; $this->_helper->viewRenderer('comment-listall'); } }// commentAction() 数据反馈 /* * newsAction() 数据新闻 * * param string $ac * * */ function newsAction(){ $ac = $this->_request->getParam('ac'); $auth = Zend_Auth::getInstance(); if($auth->hasIdentity()) { $user = $auth->getIdentity(); $u_id = $user->id; } //新闻列表 if(empty($ac) || $ac=="list") { $keyword = $this->_request->getParam('q'); $uuid = $this->_request->getParam('uuid'); $wheresql = ""; $join = ""; if(!empty($keyword)) { $this->view->q = $keyword; $search = new Search($keyword); $wheresql = $search->sql_expr(array("arc.title","arc.description")); } if(!empty($wheresql)) { $wheresql = " AND ".$wheresql; } if(!empty($uuid) && preg_match("/^[0-9A-Za-z]{8}-[0-9A-Za-z]{4}-[0-9A-Za-z]{4}-[0-9A-Za-z]{4}-[0-9A-Za-z]{12}$/",$uuid)) { $join = "LEFT JOIN news_mdnews mdnews ON mdnews.aid=arc.id"; $wheresql .= " AND mdnews.uuid='$uuid'"; } $sql = "SELECT arc.id,arc.title,arc.ts_published,arc.description,u.realname FROM news_archives arc LEFT JOIN users u ON arc.userid=u.id $join WHERE arc.is_pub>0 AND arc.ts_published<'now()' $wheresql ORDER BY arc.ts_published"; $sth = $this->db->prepare($sql); $sth->execute(); $rows = $sth->fetchAll(); $paginator = Zend_Paginator::factory($rows); $paginator->setCurrentPageNumber($this->_getParam('page')); $paginator->setItemCountPerPage(10); $paginator->setView($this->view); Zend_View_Helper_PaginationControl::setDefaultViewPartial('pagination_param.phtml'); $this->view->paginator=$paginator; } if($ac == "view") { $this->_helper->viewRenderer('news-view'); $aid = (int)$this->_request->getParam('aid'); if(empty($aid) || !is_numeric($aid)) { $this->_redirect('/error/error'); } else { $this->db->exec("UPDATE news_archives arc SET click=click+1 WHERE arc.id=$aid"); $sql = "SELECT arc.*,u.realname FROM news_archives arc LEFT JOIN users u ON u.id=arc.userid WHERE arc.id=?"; $sth = $this->db->prepare($sql); $sth -> execute(array($aid)); $row = $sth->fetch(); $this->view->info = $row; } } //新闻发布 if($ac == "add") { $this->_helper->viewRenderer('news-add'); $sql = "SELECT md.title,md.uuid FROM metadata md LEFT JOIN mdauthor a ON a.uuid = md.uuid WHERE a.userid=? AND a.status=1 "; $sth = $this->db->prepare($sql); $sth->execute(array($u_id)); $rows = $sth->fetchAll(); $this->view->md = $rows; }// $ac == add //新闻编辑 if($ac == "edit") { $this->_helper->viewRenderer('news-edit'); $aid = (int)$this->_request->getParam('aid'); if(empty($aid) || !is_numeric($aid)) { $this->_redirect('/error/error'); } $sql = "SELECT arc.*,mdarc.uuid FROM news_archives arc LEFT JOIN news_mdnews mdarc ON mdarc.aid = arc.id WHERE id=?"; $sth = $this->db->prepare($sql); $sth->execute(array($aid)); $row = $sth->fetch(); $this->view->info = $row; }//$ac == "edit" //新闻发布的ajax动作 if($ac =="addnews") { try{ $this->_helper->layout->disableLayout(); $this->_helper->viewRenderer->setNoRender(); $data = array(); $aid = $this->_request->getParam('aid'); $data['title'] = trim($this->_request->getParam('title')); $data['keyword'] = trim($this->_request->getParam('keyword')); $data['body'] = trim($this->_request->getParam('body')); $uuid = trim($this->_request->getParam('uuid')); //对参数进行预处理 foreach($data as $k=>$v) { $data[$k]=preg_replace("#]*)>(.*)#i","",$v); $data[$k]=preg_replace("#]*)>(.*)#i","",$v); $data[$k]=preg_replace("#]*)>(.*)#i","",$v); $data[$k]=str_replace("\"","“",$v); $data[$k]=str_replace("\'","‘",$v); } $msg = array(); // 合法性判断 if(mb_strlen($data['title'],"utf-8")<3) { $msg['status'] = 0; $msg['error'] = '标题太短,请重新填写'; $this->getResponse()->setHeader('Content-Type', 'application/json')->appendBody(Zend_Json::encode($msg)); return true; } if(mb_strlen($data['title'],"utf-8")>60) { $msg['status'] = 0; $msg['error'] = '标题太长,请重新填写'; $this->getResponse()->setHeader('Content-Type', 'application/json')->appendBody(Zend_Json::encode($msg)); return true; } if(empty($uuid)) { $msg['status'] = 0; $msg['error'] = '请选择对应数据'; $this->getResponse()->setHeader('Content-Type', 'application/json')->appendBody(Zend_Json::encode($msg)); return true; } if(mb_strlen($data['keyword'],"utf-8")<4) { $msg['status'] = 0; $msg['error'] = '关键词太短,请重新填写'; $this->getResponse()->setHeader('Content-Type', 'application/json')->appendBody(Zend_Json::encode($msg)); return true; } if(mb_strlen($data['keyword'],"utf-8")>40) { $msg['status'] = 0; $msg['error'] = '关键词太长,请重新填写'; $this->getResponse()->setHeader('Content-Type', 'application/json')->appendBody(Zend_Json::encode($msg)); return true; } if(mb_strlen($data['body'],"utf-8")<40) { $msg['status'] = 0; $msg['error'] = '新闻内容太短,请重新填写'; $this->getResponse()->setHeader('Content-Type', 'application/json')->appendBody(Zend_Json::encode($msg)); return true; } if(!preg_match("/^[0-9A-Za-z]{8}-[0-9A-Za-z]{4}-[0-9A-Za-z]{4}-[0-9A-Za-z]{4}-[0-9A-Za-z]{12}$/",$uuid)) { $msg['status'] = 0; $msg['error'] = '参数错误,请重试'; $this->getResponse()->setHeader('Content-Type', 'application/json')->appendBody(Zend_Json::encode($msg)); return true; } //获得描述 //删除段落及html标记 $data['description'] = mb_substr(preg_replace(array("/<(.*)>|<(.*) \/>/i","/\s/i"),array(""," "),$data['body']),0,450,"UTF-8"); //默认填充数据 $data['source'] = "西部数据中心"; $data['typeid'] = 0; $data['userid'] = $u_id; $data['keyword'] = str_replace(",",",",$data['keyword']); //新闻添加 if(empty($aid)) { $sql = "INSERT INTO news_archives (userid,title,keywords,description,image,source,ts_published,is_pub,body) VALUES (?,?,?,?,?,?,?,?,?) RETURNING id "; $sth = $this->db->prepare($sql); $ex = $sth -> execute(array($data['userid'],$data['title'],$data['keyword'],$data['description'],'',$data['source'],'now()',1,$data['body'])); //添加成功 if($ex) { //写入文章ID对应UUID的表 $archive = $sth->fetch(PDO::FETCH_ASSOC); $aid = $archive['id']; $sql = "INSERT INTO news_mdnews (aid,uuid) VALUES (?,?)"; $sth = $this->db->prepare($sql); $uuidex = $sth->execute(array($aid,$uuid)); if($uuidex) { $msg['status'] = 1; $msg['outstring'] = "新闻添加成功"; $this->getResponse()->setHeader('Content-Type', 'application/json')->appendBody(Zend_Json::encode($msg)); return true; }else{ $sql = "DELETE FROM news_archives WHERE id=$aid"; @$this->db->exec($sql); //如果新闻添加失败就删除原新闻,否则产生重复错误 $msg['status'] = 0; $msg['error'] = "新闻添加失败,请重试"; $this->getResponse()->setHeader('Content-Type', 'application/json')->appendBody(Zend_Json::encode($msg)); return true; } //添加失败 }else{ $msg['status'] = 0; $msg['error'] = "新闻添加失败,请重试"; $this->getResponse()->setHeader('Content-Type', 'application/json')->appendBody(Zend_Json::encode($msg)); return true; } }//新闻添加 end --> //新闻修改 else { $sql = "UPDATE news_archives SET title=?,keywords=?,description=?,body=? WHERE id=? AND userid=?"; $sth = $this->db->prepare($sql); $ex = $sth -> execute(array($data['title'],$data['keyword'],$data['description'],$data['body'],$aid,$data['userid'])); if($ex) { $msg['status'] = 1; $msg['outstring'] = "新闻编辑成功"; $this->getResponse()->setHeader('Content-Type', 'application/json')->appendBody(Zend_Json::encode($msg)); return true; }else{ $msg['status'] = 0; $msg['outstring'] = "新闻编辑失败,请重试"; $this->getResponse()->setHeader('Content-Type', 'application/json')->appendBody(Zend_Json::encode($msg)); return true; } }//新闻修改 end --> }catch(Exception $e){ if($this->debug==0) { $msg['status'] = 0; if(empty($aid)) {$msg['error'] = "新闻添加失败,请重试";} else {$msg['error'] = "新闻编辑失败,请重试";} $this->getResponse()->setHeader('Content-Type', 'application/json')->appendBody(Zend_Json::encode($msg)); return true; }else{ $msg['status'] = 0; $msg['error'] = "新闻添加/编辑失败,请重试:".$e->getMessage(); $this->getResponse()->setHeader('Content-Type', 'application/json')->appendBody(Zend_Json::encode($msg)); return true; } }//catch end }//$ac = 'newsadd' endif; }//newsAction() 数据新闻 function viewauthorsAction(){ $this->_helper->viewRenderer('view-authors'); $uuid = $this->_request->getParam('uuid'); if(preg_match("/^[0-9A-Za-z]{8}-[0-9A-Za-z]{4}-[0-9A-Za-z]{4}-[0-9A-Za-z]{4}-[0-9A-Za-z]{12}$/",$uuid)) { $sql = "SELECT u.realname,u.unit,u.email,m.title,m.description FROM normalmetadata m LEFT JOIN mdauthor a ON m.uuid=a.uuid LEFT JOIN users u ON u.id=a.userid WHERE status>=0 AND m.uuid=? AND a.status=1 ORDER BY status DESC,a.id DESC"; $sth = $this->db->prepare($sql); $sth->execute(array($uuid)); $rows = $sth->fetchAll(); $paginator = Zend_Paginator::factory($rows); $paginator->setCurrentPageNumber($this->_getParam('page')); $paginator->setItemCountPerPage(10); $paginator->setView($this->view); Zend_View_Helper_PaginationControl::setDefaultViewPartial('pagination_param.phtml'); $this->view->paginator=$paginator; }else{ $this->view->error = "参数有误"; } } function versionAction() { $ac = $this->_request->getParam('ac'); $uuid = $this->_request->getParam('uuid'); $auth = Zend_Auth::getInstance(); if($auth->hasIdentity()) { $user = $auth->getIdentity(); $u_id = $user->id; } //查看单条数据的所有版本 if (!empty($uuid) && empty($ac)) { //view the versions of the data $sql = "SELECT md.title,md.uuid,v.ts_created,v.changelog,v.userid,v.id,u.username,u.realname FROM mdversion v LEFT JOIN metadata md ON md.uuid=v.uuid LEFT JOIN mdauthor a ON md.uuid=a.uuid left join users u on v.userid=u.id WHERE md.title IS NOT NULL AND a.userid=? and v.uuid=? AND a.status=1 order by v.ts_created desc "; $sth = $this->db->prepare($sql); $sth->execute(array($u_id,$uuid)); $rows = $sth->fetchAll(); @$this->view->mdtitle=$rows[0]['title']; $paginator = Zend_Paginator::factory($rows); $paginator->setCurrentPageNumber($this->_getParam('page')); $paginator->setItemCountPerPage(15); $paginator->setView($this->view); Zend_View_Helper_PaginationControl::setDefaultViewPartial('pagination_param.phtml'); $this->view->paginator=$paginator; } //查看所有版本列表 else if((empty($ac) && empty($uuid))|| $ac=='list') { $sql = "SELECT md.title,md.uuid,v.ts_created,v.changelog,v.userid,v.id,u.username,u.realname FROM mdversion v LEFT JOIN metadata md ON md.uuid=v.uuid LEFT JOIN mdauthor a ON md.uuid=a.uuid left join users u on v.userid=u.id WHERE md.title IS NOT NULL AND a.userid=? AND a.status=1 order by v.ts_created desc "; $sth = $this->db->prepare($sql); $sth->execute(array($u_id)); $rows = $sth->fetchAll(); $paginator = Zend_Paginator::factory($rows); $paginator->setCurrentPageNumber($this->_getParam('page')); $paginator->setItemCountPerPage(15); $paginator->setView($this->view); Zend_View_Helper_PaginationControl::setDefaultViewPartial('pagination_param.phtml'); $this->view->paginator=$paginator; } //按数据浏览 else if($ac=="bydata") { $keywords = $this->_request->getParam('q'); if(!empty($keywords)) $this->view->q = $keywords; $sql = "SELECT md.title,md.uuid,count(v.id) as c FROM mdversion v LEFT JOIN metadata md ON md.uuid=v.uuid LEFT JOIN mdauthor a ON md.uuid=a.uuid WHERE md.title IS NOT NULL AND a.userid=? AND a.status=1"; if(!empty($keywords)) { $search=new Search($keywords); $where=$search->sql_expr(array("md.title","md.description")); $sql.=' and '.$where; } $sql.=" group by md.uuid,md.title"; $sth = $this->db->prepare($sql); $sth->execute(array($u_id)); $rows = $sth->fetchAll(); $paginator = Zend_Paginator::factory($rows); $paginator->setCurrentPageNumber($this->_getParam('page')); $paginator->setItemCountPerPage(10); $paginator->setView($this->view); Zend_View_Helper_PaginationControl::setDefaultViewPartial('pagination_param.phtml'); $this->view->paginator=$paginator; $this->_helper->viewRenderer('version-bydata'); } //删除某个版本 else if($ac=="delete") { $this->_helper->layout->disableLayout(); $this->_helper->viewRenderer->setNoRender(); $data = ""; try{ $id = $this->_request->getParam('id'); if(empty($id) || !is_numeric($id)) { $data = array("error"=>"参数错误"); $this->jsonexit($data); return true; } $sql = "DELETE FROM mdversion v USING mdauthor a WHERE v.uuid=a.uuid and v.id=? AND a.userid=? AND a.status=1"; $sth = $this->db->prepare($sql); $ex = $sth -> execute(array($id,$u_id)); if($ex) { $data = array("deleted"=>$id,"error"=>$this->alertbox('ok','删除成功')); $this->jsonexit($data); return true; }else{ $data = array("error"=>$this->alertbox('error','删除失败,请确认权限后重试')); $this->jsonexit($data); return true; } }catch(Exception $e) { $msg = "删除失败,请确认权限后重试"; if($this->debug>0) {$msg .= $e->getMessage();} $data = array("error"=>$this->alertbox('error',$msg)); $this->jsonexit($data); return true; } } //恢复到geonetwork else if($ac == "restore") { $this->_helper->layout->disableLayout(); $this->_helper->viewRenderer->setNoRender(); $data = ""; try{ $id = $this->_request->getParam('id'); if(empty($id) || !is_numeric($id)) { $data = array("error"=>"参数错误"); $this->jsonexit($data); return true; } $this->wdb=Zend_Db::factory($this->view->config->geonetwork); $sql = "SELECT v.xml,v.uuid FROM mdversion v LEFT JOIN mdauthor a ON a.uuid=v.uuid WHERE v.id=? AND a.userid=? AND a.status=1"; $sth = $this->db->prepare($sql); $sth ->execute(array($id,$u_id)); $row = $sth->fetch(); $sql = "SELECT data FROM metadata WHERE uuid=?"; $sth = $this->wdb->prepare($sql); $sth ->execute(array($row['uuid'])); $row_geo = $sth->fetch(); if($row['xml']==$row_geo['data']) { $data = array("error"=>$this->alertbox('warning','无须恢复,元数据相同')); $this->jsonexit($data); return true; } $sql = "UPDATE metadata SET data=? WHERE uuid=?"; $sth = $this->wdb->prepare($sql); $ex = $sth ->execute(array($row['xml'],$row['uuid'])); if($ex) { $data = array("error"=>$this->alertbox('ok','恢复成功')); $this->jsonexit($data); return true; }else{ $data = array("error"=>$this->alertbox('error','恢复失败,请确认权限后重试')); $this->jsonexit($data); return true; } }catch(Exception $e) { $msg = "恢复失败,请确认权限后重试"; if($this->debug>0) {$msg .= $e->getMessage();} $data = array("error"=>$this->alertbox('error',$msg)); $this->jsonexit($data); return true; } } //发布到评审 else if($ac == "commit") { $this->_helper->layout->disableLayout(); $this->_helper->viewRenderer->setNoRender(); $data = ""; try{ $id = $this->_request->getParam('id'); if(empty($id) || !is_numeric($id)) { $data = array("error"=>"参数错误"); $this->jsonexit($data); return true; } $changelog = $this->_request->getParam('changelog'); if(empty($changelog)) { $data = array("error"=>$this->alertbox('warning','请输入变更信息')); $this->jsonexit($data); return true; } // 1. 权限认定 $sql="select a.* from mdauthor a left join mdversion v on a.uuid=v.uuid where a.status=1 and a.userid=? and v.id=?"; $sth=$this->db->prepare($sql); $sth->execute(array($u_id,$id)); $row=$sth->fetch(); if (empty($row)) { $data = array("error"=>'无权限修改数据'); $this->jsonexit($data); return true; } // 2. 获取数据评审状态 $sql = "SELECT s.* FROM mdstatus s left join mdversion v on s.uuid=v.uuid WHERE v.id=?"; $sth = $this->db->prepare($sql); $sth->execute(array($id)); $row = $sth->fetch(); if (empty($row)) //无对应记录 { // do } else if ($row['id']==-1) //取消发布的数据 { //do something. } else if ($row['id']==0) //初始状态 { //do } else if ($row['id']==1)//接收 { // } else if ($row['id']==2)//已发送过外审邮件,需由编辑告知变化信息 { //do } else if ($row['id']==3 || $row['id']==4)//专家在审理中 { //do } else if ($row['id']==5)//数据已经发布,再次修改后将只通知管理员,保留发布状态 { //do } if(!empty($row['id'])) { $data = array("error"=>$this->alertbox('warning','该数据已经在评审中,请勿重复提交')); $this->jsonexit($data); return true; } $sql = "UPDATE mdversion SET changelog=?,userid=? WHERE id=?"; $sth = $this->db->prepare($sql); $ex_changelog = $sth->execute(array($changelog,$u_id,$id)); if($ex_changelog){ $sql = "SELECT v.uuid FROM mdversion v LEFT JOIN mdauthor a ON a.uuid=v.uuid WHERE v.id=? AND a.userid=? AND a.status=1"; $sth = $this->db->prepare($sql); $sth->execute(array($id,$u_id)); $row = $sth->fetch(); $sql = "INSERT INTO mdstatus (uuid,status,userid) VALUES (?,?,?)"; $sth = $this->db->prepare($sql); $ex = $sth->execute(array($row['uuid'],1,$u_id)); if($ex) { $data = array("commited"=>1,"error"=>$this->alertbox('ok','提交成功!')); $this->jsonexit($data); return true; }else{ $data = array("error"=>$this->alertbox('error','提交失败,请确认权限后重试')); $this->jsonexit($data); return true; } }else{ $data = array("error"=>$this->alertbox('error','提交失败,刷新后重试')); $this->jsonexit($data); return true; } }catch(Exception $e) { $msg = "提交失败,请确认权限后重试"; if($this->debug>0) {$msg .= $e->getMessage();} $data = array("error"=>$this->alertbox('error',$msg)); $this->jsonexit($data); return true; } }//发布到评审 //与前一个版本对比 else if($ac == "diff") { $this->_helper->viewRenderer('version-diff'); $id = $this->_request->getParam('id'); if(empty($id) || !is_numeric($id)) { $this->view->error = "参数错误"; return true; } $sql = "SELECT v.uuid,md.title FROM mdversion v LEFT JOIN mdauthor a ON a.uuid=v.uuid LEFT JOIN metadata md ON v.uuid=md.uuid WHERE v.id=? AND a.userid=? AND a.status=1"; $sth = $this->db->prepare($sql); $sth -> execute(array($id,$u_id)); $row = $sth->fetch(); $sql = "SELECT v.* FROM mdversion v WHERE v.uuid=? AND v.id<=? ORDER BY v.ts_created DESC LIMIT ?"; $sth = $this->db->prepare($sql); $sth -> execute(array($row['uuid'],$id,2)); $rows = $sth->fetchAll(); if(count($rows)<2) { $this->view->error = "对比失败:之前没有版本可以对比"; return true; } $this->view->info = $row; $this->view->data = $rows; } }// versionAction() 数据版本管理 //新建元数据 function newdataAction() { $ac = $this->_request->getParam('ac'); $id = $this->_request->getParam('id'); $this->wdb=Zend_Db::factory($this->view->config->geonetwork); $auth = Zend_Auth::getInstance(); if($auth->hasIdentity()) { $user = $auth->getIdentity(); $u_id = $user->id; } //在geonetwork中查看单条数据 if (!empty($id) && empty($ac)) { $this->view->url='metadata.show?id='.$id; $this->_helper->viewRenderer('newdata-view'); } //查看属于自己的所有的未提交数据列表 else if((empty($ac) && empty($uuid))|| $ac=='list') { $sql = "SELECT (regexp_matches(gn.data,'(.*)'))[1] as title,gn.id,gn.uuid FROM geonetworkmetadata gn WHERE gn.uuid not in (select uuid from metadata) and gn.owner=? order by gn.id desc "; $sth = $this->db->prepare($sql); $sth->execute(array($u_id)); $rows = $sth->fetchAll(); $paginator = Zend_Paginator::factory($rows); $paginator->setCurrentPageNumber($this->_getParam('page')); $paginator->setItemCountPerPage(15); $paginator->setView($this->view); Zend_View_Helper_PaginationControl::setDefaultViewPartial('pagination_param.phtml'); $this->view->paginator=$paginator; } //元数据导入 else if($ac=="import") { $this->_helper->viewRenderer('newdata-import'); } //从模板新建元数据 else if($ac=="add") { $keywords = $this->_request->getParam('q'); if(!empty($keywords)) { $this->view->q = $keywords; $sql = "SELECT md.title,md.uuid,md.description,gn.id as gid FROM normalmetadata md left join geonetworkmetadata gn on md.uuid=gn.uuid WHERE gn.id is not null"; $search=new Search($keywords); $where=$search->sql_expr(array("md.title","md.description")); $sql.=' and '.$where; $sql.=" order by md.ts_created desc"; $sth = $this->db->prepare($sql); $sth->execute(); $rows = $sth->fetchAll(); $paginator = Zend_Paginator::factory($rows); $paginator->setCurrentPageNumber($this->_getParam('page')); $paginator->setItemCountPerPage(10); $paginator->setView($this->view); Zend_View_Helper_PaginationControl::setDefaultViewPartial('pagination_param.phtml'); $this->view->paginator=$paginator; } $this->_helper->viewRenderer('newdata-add'); } } //文献管理 function literatureAction() { $ac = $this->_request->getParam('ac'); $uuid = $this->_request->getParam('uuid'); $id = $this->_request->getParam('id'); $auth = Zend_Auth::getInstance(); if($auth->hasIdentity()) { $user = $auth->getIdentity(); $u_id = $user->id; } //查看单条数据的所有文献 if (!empty($uuid) && empty($ac)) { $sql = "SELECT md.title,md.uuid,r.id,r.reference,r.link FROM mdref mr LEFT JOIN metadata md ON md.uuid=mr.uuid LEFT JOIN mdauthor a ON md.uuid=a.uuid left join reference r on mr.refid=r.id WHERE md.title IS NOT NULL AND a.userid=? and mr.uuid=? AND a.status=1 order by md.ts_created desc "; $sth = $this->db->prepare($sql); $sth->execute(array($u_id,$uuid)); $rows = $sth->fetchAll(); @$this->view->mdtitle=$rows[0]['title']; $paginator = Zend_Paginator::factory($rows); $paginator->setCurrentPageNumber($this->_getParam('page')); $paginator->setItemCountPerPage(15); $paginator->setView($this->view); Zend_View_Helper_PaginationControl::setDefaultViewPartial('pagination_param.phtml'); $this->view->paginator=$paginator; $this->_helper->viewRenderer('literature-viewdata'); } //查看单条文献的所有数据 if (!empty($id) && empty($ac)) { $sql = "SELECT md.title,md.uuid,r.id,r.reference,r.link,(a.userid-?) as isauthor FROM mdref mr LEFT JOIN metadata md ON md.uuid=mr.uuid LEFT JOIN mdauthor a ON md.uuid=a.uuid left join reference r on mr.refid=r.id WHERE md.title IS NOT NULL AND mr.refid=? AND a.status=1 order by md.ts_created desc "; $sth = $this->db->prepare($sql); $sth->execute(array($u_id,$id)); $rows = $sth->fetchAll(); @$this->view->mdtitle=$rows[0]['reference']; $paginator = Zend_Paginator::factory($rows); $paginator->setCurrentPageNumber($this->_getParam('page')); $paginator->setItemCountPerPage(15); $paginator->setView($this->view); Zend_View_Helper_PaginationControl::setDefaultViewPartial('pagination_param.phtml'); $this->view->paginator=$paginator; $this->_helper->viewRenderer('literature-viewliter'); } //查看所有文献列表 else if((empty($ac) && empty($uuid)) && empty($id)) { $keywords = $this->_request->getParam('q'); $sql = "SELECT md.title,md.uuid,r.reference,r.id,mr.id as mrid FROM mdref mr LEFT JOIN metadata md ON md.uuid=mr.uuid LEFT JOIN mdauthor a ON md.uuid=a.uuid left join reference r on mr.refid=r.id WHERE md.title IS NOT NULL AND a.userid=? AND a.status=1"; if(!empty($keywords)) $this->view->q = $keywords; if(!empty($keywords)) { $search=new Search($keywords); $where=$search->sql_expr(array("r.reference","md.title","md.description")); $sql.=' and '.$where; } $sql.=" order by md.ts_created desc"; $sth = $this->db->prepare($sql); $sth->execute(array($u_id)); $rows = $sth->fetchAll(); $paginator = Zend_Paginator::factory($rows); $paginator->setCurrentPageNumber($this->_getParam('page')); $paginator->setItemCountPerPage(15); $paginator->setView($this->view); Zend_View_Helper_PaginationControl::setDefaultViewPartial('pagination_param.phtml'); $this->view->paginator=$paginator; } //按文献浏览 else if($ac=="byliter") { $keywords = $this->_request->getParam('q'); if(!empty($keywords)) $this->view->q = $keywords; $sql = "SELECT count(md.uuid) as c,r.reference,r.id FROM reference r left join mdref mr on r.id=mr.refid LEFT JOIN metadata md ON md.uuid=mr.uuid LEFT JOIN mdauthor a ON md.uuid=a.uuid WHERE md.title IS NOT NULL AND a.userid=? AND a.status=1"; if(!empty($keywords)) { $search=new Search($keywords); $where=$search->sql_expr(array("r.reference")); $sql.=' and '.$where; } $sql.=" group by r.reference,r.id"; $sth = $this->db->prepare($sql); $sth->execute(array($u_id)); $rows = $sth->fetchAll(); $paginator = Zend_Paginator::factory($rows); $paginator->setCurrentPageNumber($this->_getParam('page')); $paginator->setItemCountPerPage(10); $paginator->setView($this->view); Zend_View_Helper_PaginationControl::setDefaultViewPartial('pagination_param.phtml'); $this->view->paginator=$paginator; $this->_helper->viewRenderer('literature-byliter'); } //按数据浏览 else if($ac=="bydata") { $keywords = $this->_request->getParam('q'); if(!empty($keywords)) $this->view->q = $keywords; $sql = "SELECT md.title,md.uuid,count(mr.id) as c FROM metadata md LEFT JOIN mdref mr ON md.uuid=mr.uuid LEFT JOIN mdauthor a ON md.uuid=a.uuid left join reference r on mr.refid=r.id WHERE md.title IS NOT NULL AND a.userid=? AND a.status=1"; if(!empty($keywords)) { $search=new Search($keywords); $where=$search->sql_expr(array("md.title","md.description")); $sql.=' and '.$where; } $sql.=" group by md.uuid,md.title"; $sth = $this->db->prepare($sql); $sth->execute(array($u_id)); $rows = $sth->fetchAll(); $paginator = Zend_Paginator::factory($rows); $paginator->setCurrentPageNumber($this->_getParam('page')); $paginator->setItemCountPerPage(10); $paginator->setView($this->view); Zend_View_Helper_PaginationControl::setDefaultViewPartial('pagination_param.phtml'); $this->view->paginator=$paginator; $this->_helper->viewRenderer('literature-bydata'); } //添加文献信息 else if($ac == "add") { $this->_helper->layout->disableLayout(); $this->_helper->viewRenderer->setNoRender(); $data = ""; try{ $uuid = $this->_request->getParam('uuid'); $ref=$this->_request->getParam('ref'); $reftype=$this->_request->getParam('reftype'); if(empty($uuid) || empty($ref) || !is_numeric($reftype)) { $data = array("error"=>"参数错误"); $this->jsonexit($data); return true; } $sql="select * from mdauthor where userid=? and uuid=? and status=1"; $sth = $this->db->prepare($sql); $sth->execute(array($u_id,$uuid)); $row = $sth->fetch(); if (empty($row)) { $data = array("error"=>$this->alertbox('warning','您不是该数据作者,无法添加对应文献信息。')); $this->jsonexit($data); return true; } $sql="select id from reference where reference=?"; $sth = $this->db->prepare($sql); $sth->execute(array($ref)); $row = $sth->fetch(); if (!$row) { $sql="insert into reference (reference,link) values(?,?)"; $sth = $this->db->prepare($sql); $sth->execute(array(trim($ref),'')); $sql="select id from reference where reference=?"; $sth = $this->db->prepare($sql); $sth->execute(array(trim($ref))); $row = $sth->fetch(); } $sql="insert into mdref (uuid,refid,reftype) values(?,?,?)"; $sth = $this->db->prepare($sql); $ex=$sth->execute(array($uuid,$row['id'],$reftype)); if($ex) { $data = array("commited"=>1,"error"=>$this->alertbox('ok','成功添加文献!')); $this->jsonexit($data); return true; }else{ $data = array("error"=>$this->alertbox('error','提交失败,请确认权限后重试')); $this->jsonexit($data); return true; } }catch(Exception $e) { $msg = "提交失败,请确认权限后重试"; if($this->debug>0) {$msg .= $e->getMessage();} $data = array("error"=>$this->alertbox('error',$msg)); $this->jsonexit($data); return true; } }//添加文献 //删除某个文献 else if($ac=="delete") { $this->_helper->layout->disableLayout(); $this->_helper->viewRenderer->setNoRender(); $data = ""; $id = $this->_request->getParam('id'); $uuid = $this->_request->getParam('uuid'); if(empty($uuid) || !is_numeric($id)) { $data = array("error"=>"参数错误"); $this->jsonexit($data); return true; } try{ $sql = "DELETE FROM mdref r USING mdauthor a WHERE r.uuid=a.uuid and r.refid=? and r.uuid=? AND a.userid=? AND a.status=1"; $sth = $this->db->prepare($sql); $ex = $sth -> execute(array($id,$uuid,$u_id)); if($ex) { $data = array("deleted"=>$id.$uuid,"error"=>$this->alertbox('ok','删除成功')); $this->jsonexit($data); return true; }else{ $data = array("error"=>$this->alertbox('error','删除失败,请确认权限后重试')); $this->jsonexit($data); return true; } }catch(Exception $e) { $msg = "删除失败,请确认权限后重试"; if($this->debug>0) {$msg .= $e->getMessage();} $data = array("error"=>$this->alertbox('error',$msg)); $this->jsonexit($data); return true; } } } //成为作者后的后继处理工作 private function author_first($uuid,$author) { $sql="insert into mdversion (xml,ts_created,uuid,changelog,userid) select x.data,m.ts_created,?,?,? from metadata m left join xml x on m.id=x.id left join mdversion v on m.uuid=v.uuid where m.uuid=? and v.changelog is null"; $sth=$this->db->prepare($sql); try { $sth->execute(array($uuid,'初始版本 version 1.0',$author,$uuid)); } catch(Exception $e){ // do nothing here. // 说明之前已经有对应数据 } $this->wdb=Zend_Db::factory($this->view->config->geonetwork); $sql="update metadata set owner=? where uuid=?"; $sth=$this->wdb->prepare($sql); $sth->execute(array($author,$uuid)); } /* * jsonexit() 退出并返回json数据 * * param array $data 要返回的JSON数据,可以是任意数组 * * return JSON-response */ public function jsonexit($data){ $this->getResponse()->setHeader('Content-Type', 'application/json')->appendBody(Zend_Json::encode($data)); return true; }//jsonexit() 退出并返回json数据 //ajax 提示框 public function alertbox($type='',$body){ if($type == "error") { $img = ''; $text = '

'.$body.'

'; return $img.$text; } if($type == "ok") { $img = ''; $text = '

'.$body.'

'; return $img.$text; } if($type == "warning") { $img = ''; $text = '

'.$body.'

'; return $img.$text; } if(empty($type)) { $text = '

'.$body.'

'; return $text; } } }