298 lines
9.1 KiB
PHP
298 lines
9.1 KiB
PHP
|
<?php
|
|||
|
|
class SubmitController extends Zend_Controller_Action
|
|||
|
|
{
|
|||
|
|
private $limit=10;
|
|||
|
|
|
|||
|
|
//调试模式
|
|||
|
|
// 调试模式中将显示全部错误细节，电子邮件将发往调试邮箱
|
|||
|
|
// 1 为开启
|
|||
|
|
// 0 为关闭
|
|||
|
|
public $debug = 1;
|
|||
|
|
|
|||
|
|
//调试模式邮箱地址
|
|||
|
|
public $debug_email = "la5c@qq.com";
|
|||
|
|
|
|||
|
|
|
|||
|
|
function preDispatch()
|
|||
|
|
{
|
|||
|
|
$this->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()帮助文档
|
|||
|
|
|
|||
|
|
//新建元数据
|
|||
|
|
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,'<resTitle>(.*)</resTitle>'))[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;
|
|||
|
|
}
|
|||
|
|
$sql="select id,(regexp_matches(data,'<resTitle>(.*)</resTitle>'))[1] as title from metadata where istemplate='y' and schemaid='iso19115'";
|
|||
|
|
$sth=$this->wdb->prepare($sql);
|
|||
|
|
$sth->execute();
|
|||
|
|
$this->view->templates=$sth->fetchAll();
|
|||
|
|
$this->_helper->viewRenderer('newdata-add');
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
//提交数据
|
|||
|
|
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. 权限认定：当前用户必须和其owner相同
|
|||
|
|
// 数据应当没有评审状态，没有作者信息
|
|||
|
|
$sql="select gn.id from geonetworkmetadata gn
|
|||
|
|
left join mdstatus s on gn.uuid=s.uuid
|
|||
|
|
left join mdauthor a on s.uuid=a.uuid
|
|||
|
|
where s.id is not null and a.id is not null and gn.id=?";
|
|||
|
|
$sth=$this->db->prepare($sql);
|
|||
|
|
$sth->execute(array($id));
|
|||
|
|
$row=$sth->fetch();
|
|||
|
|
if (!emtpy($row))
|
|||
|
|
{
|
|||
|
|
$data = array("error"=>'错误的入口');
|
|||
|
|
$this->jsonexit($data);
|
|||
|
|
return true;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
$sql="select uuid from metadata where id=? and owner=?";
|
|||
|
|
$sth=$this->wdb->prepare($sql);
|
|||
|
|
$sth->execute(array($id,$u_id));
|
|||
|
|
$row=$sth->fetch();
|
|||
|
|
if (empty($row))
|
|||
|
|
{
|
|||
|
|
$data = array("error"=>'无权限修改数据');
|
|||
|
|
$this->jsonexit($data);
|
|||
|
|
return true;
|
|||
|
|
}
|
|||
|
|
// 保存数据作者信息
|
|||
|
|
$sql="insert into mdauthor (uuid,userid,ts_activated,status) values(?,?,now(),1)";
|
|||
|
|
$sth=$this->db->query($sql,array($row['uuid'],$u_id));
|
|||
|
|
|
|||
|
|
// 2. 保存变化记录 save changelog & userid for the latest version
|
|||
|
|
$sql = "UPDATE mdversion SET changelog=?,userid=? WHERE id in (select id from mdversion where uuid=? order by ts_created desc limit 1)";
|
|||
|
|
$this->db->query($sql,array($changelog,$u_id,$row['uuid']));
|
|||
|
|
|
|||
|
|
// 3. 保存数据评审状态
|
|||
|
|
//导入元数据
|
|||
|
|
$iso=new ISO19115();
|
|||
|
|
$iso->saveDB($this->db,$row['xml']);
|
|||
|
|
//进入评审库
|
|||
|
|
$sql="insert into mdstatus (uuid,status,userid) select uuid,0,? from mdversion where id=?";
|
|||
|
|
$this->db->query($sql,array($u_id,$id));
|
|||
|
|
|
|||
|
|
//email to admin
|
|||
|
|
$mail=new WestdcMailer($this->view->config->smtp);
|
|||
|
|
$mail->setFrom($this->view->config->service->email,'西部数据中心服务组');
|
|||
|
|
$mailtp=new EmailText($this->db,"metadata-new-admin",array(
|
|||
|
|
'user' => $user->username,
|
|||
|
|
'uuid' => $iso->uuid,
|
|||
|
|
'email'=> $user->email,
|
|||
|
|
//元数据标题
|
|||
|
|
'title'=> $iso->resTitle,
|
|||
|
|
));
|
|||
|
|
$mail->setBodyText($mailtp->getBody());
|
|||
|
|
$mail->setSubject($mailtp->getSubject());
|
|||
|
|
if($this->debug==0)
|
|||
|
|
{
|
|||
|
|
$mail->addTo($this->view->config->service->email);
|
|||
|
|
}else{
|
|||
|
|
$mail->addTo($this->debug_email);
|
|||
|
|
}
|
|||
|
|
$mail->send();
|
|||
|
|
|
|||
|
|
unset($mail);
|
|||
|
|
unset($mailtp);
|
|||
|
|
//email to author
|
|||
|
|
$mail=new WestdcMailer($this->view->config->smtp);
|
|||
|
|
$mail->setFrom($this->view->config->service->email,'西部数据中心服务组');
|
|||
|
|
$mailtp=new EmailText($this->db,"metadata-new-author",array(
|
|||
|
|
'user' => $user->username,
|
|||
|
|
'uuid' => $iso->uuid,
|
|||
|
|
'email'=> $user->email,
|
|||
|
|
//元数据标题
|
|||
|
|
'title'=> $iso->resTitle,
|
|||
|
|
));
|
|||
|
|
$mail->setBodyText($mailtp->getBody());
|
|||
|
|
$mail->setSubject($mailtp->getSubject());
|
|||
|
|
if($this->debug==0)
|
|||
|
|
{
|
|||
|
|
$mail->addTo($user->email);
|
|||
|
|
$mail->addCc($this->view->config->service->email);
|
|||
|
|
}else{
|
|||
|
|
$mail->addTo($this->debug_email);
|
|||
|
|
}
|
|||
|
|
@$mail->send();
|
|||
|
|
|
|||
|
|
$data = array("commited"=>1,"error"=>$this->alertbox('ok','该版本已经成功提交，请等待数据中心进一步处理!'));
|
|||
|
|
$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 = '<img src="/images/alert_big_error.png" />';
|
|||
|
|
$text = '<h4>'.$body.'</h4>';
|
|||
|
|
return $img.$text;
|
|||
|
|
}
|
|||
|
|
if($type == "ok")
|
|||
|
|
{
|
|||
|
|
$img = '<img src="/images/alert_big_ok.png" />';
|
|||
|
|
$text = '<h4>'.$body.'</h4>';
|
|||
|
|
return $img.$text;
|
|||
|
|
}
|
|||
|
|
if($type == "warning")
|
|||
|
|
{
|
|||
|
|
$img = '<img src="/images/alert_big_warning.png" />';
|
|||
|
|
$text = '<h4>'.$body.'</h4>';
|
|||
|
|
return $img.$text;
|
|||
|
|
}
|
|||
|
|
if(empty($type))
|
|||
|
|
{
|
|||
|
|
$text = '<h4>'.$body.'</h4>';
|
|||
|
|
return $text;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|