2011-09-20 02:58:44 +00:00
< ? php
class DataController extends Zend_Controller_Action
{
private $limit = 10 ;
function preDispatch ()
{
$this -> db = Zend_Registry :: get ( 'db' );
$this -> view -> config = Zend_Registry :: get ( 'config' );
$this -> messenger = $this -> _helper -> getHelper ( 'FlashMessenger' );
$this -> view -> messages = $this -> messenger -> getMessages ();
2013-03-12 04:27:01 +00:00
$this -> view -> theme = new Theme ();
2013-03-19 09:16:41 +00:00
$this -> view -> main_nav_pageID = " data " ;
2013-05-13 02:50:06 +00:00
$this -> view -> nav = array (
array ( 'link' => '/' , 'title' => '<i class="icon-home"></i>' ),
array ( 'link' => '/data' , 'title' => $this -> view -> config -> title -> data ),
);
2011-09-20 02:58:44 +00:00
}
function indexAction ()
{
//序列
2013-05-17 08:34:47 +00:00
$state = $this -> db -> query ( 'select s.id,s.name,count(*) as count from series s,dataseries d where d.sid=s.id and length(s.name)>2 group by s.id,s.name order by count desc limit 15' );
2011-09-20 02:58:44 +00:00
$this -> view -> serie = $state -> fetchAll ();
//分类
2011-10-26 09:28:19 +00:00
$state = $this -> db -> query ( 'select c.code,name,name_zh,count(*) from category c,categorycode cc where c.code=cc.code group by c.code,cc.name,cc.name_zh' );
2011-09-20 02:58:44 +00:00
$this -> view -> category = $state -> fetchAll ();
//关键词
2011-10-26 09:28:19 +00:00
$state = $this -> db -> query ( " select keyword,count(*) from keyword where keytype='place' group by keyword order by count desc limit 20 " );
2011-09-20 02:58:44 +00:00
$k1 = $state -> fetchAll ();
2013-04-11 08:14:02 +00:00
$state = $this -> db -> query ( " select keyword,count(*) from keyword where keytype='theme' group by keyword order by count desc limit 20 " );
//$state=$this->db->query("select k.keyword,count(k.keyword) from keyword k left join normalmetadata m on k.id=m.id where k.keytype='theme' and (m.uuid in (select uuid from dataorder group by uuid order by count(uuid) desc limit 20)) group by k.keyword order by count(k.keyword) desc limit 20");
2011-09-20 02:58:44 +00:00
$k2 = $state -> fetchAll ();
2011-10-26 09:28:19 +00:00
$state = $this -> db -> query ( " select keyword,count(*) from keyword where keytype='discipline' group by keyword order by count desc limit 20 " );
2011-09-20 02:58:44 +00:00
$k3 = $state -> fetchAll ();
2011-10-26 09:28:19 +00:00
$state = $this -> db -> query ( " select keyword,count(*) from keyword where keytype='stratum' group by keyword order by count desc limit 20 " );
2011-09-20 02:58:44 +00:00
$k4 = $state -> fetchAll ();
2013-04-11 08:14:02 +00:00
$state = $this -> db -> query ( " select keyword,count(*) from keyword where keytype='temporal' group by keyword order by count desc limit 20 " );
//$state=$this->db->query("select k.keyword,count(k.keyword) from keyword k left join normalmetadata m on k.id=m.id where k.keytype='temporal' and (m.uuid in (select uuid from dataorder group by uuid order by count(uuid) desc limit 20)) group by k.keyword order by count(k.keyword) desc limit 20");
2011-09-20 02:58:44 +00:00
$k5 = $state -> fetchAll ();
$this -> view -> keywords = array ( 'place' => $k1 , 'theme' => $k2 , 'discipline' => $k3 , 'stratum' => $k4 , 'temporal' => $k5 );
//最新10个入库数据
2011-10-26 09:28:19 +00:00
$state = $this -> db -> query ( 'select id,uuid,title from normalmetadata order by id desc limit 10' );
2011-09-20 02:58:44 +00:00
$this -> view -> metadata = $state -> fetchAll ();
//特色数据
//服务
$l = new mydir ( $this -> view -> config -> paths -> newsletter , " newsletter_*.pdf " );
$this -> view -> newsletter = $l -> getLast ();
$name = basename ( $this -> view -> newsletter , '.pdf' );
list (, $this -> view -> newsletterno ) = explode ( " _ " , $name );
$this -> view -> addHelperPath ( 'helper' , 'Zend_View_Helper_' );
$form = new MaillistForm ();
$form -> submit -> setLabel ( '输入邮件地址,订阅数据通讯列表' );
$this -> view -> form = $form ;
if ( $this -> _request -> isPost ()) {
//发送邮件
$formData = $this -> _request -> getPost ();
if ( $form -> isValid ( $formData )) {
$mail = new WestdcMailer ( $this -> view -> config -> smtp );
$mail -> setFrom ( $formData [ 'email' ]);
$mail -> setBodyText ( " . " );
$mail -> setSubject ( 'subscribe' );
$mail -> addTo ( $this -> view -> config -> reportemail );
$mail -> send ();
$this -> messenger -> addMessage ( '订阅成功,请检查您的邮件!' );
$this -> _redirect ( '/data/' );
}
} else {
$auth = Zend_Auth :: getInstance ();
if ( $auth -> hasIdentity ()) {
$user = $auth -> getIdentity ();
$formData [ 'email' ] = $user -> email ;
$form -> populate ( $formData );
}
}
$searchform = new SearchForm ();
$this -> view -> searchform = $searchform ;
//其他连接
}
function onlinelistAction ()
{
$page = ( int ) $this -> _request -> getParam ( 'page' );
if ( empty ( $page )) $page = 1 ;
$limit = 30 ;
$offset = $limit * ( $page - 1 );
2011-10-26 09:28:19 +00:00
$state = $this -> db -> query ( 'select count(*) from normalmetadata where datatype=0' );
2011-09-20 02:58:44 +00:00
$row = $state -> fetchAll ();
$sum = $row [ 0 ][ 'count' ];
2011-10-26 09:28:19 +00:00
$select = $this -> db -> select ();
$select -> from ( 'normalmetadata' , '*' ) -> where ( 'datatype=0' ) -> order ( 'title' ) -> limitPage ( $page , $limit );
$this -> view -> metadata = $this -> db -> fetchAll ( $select );
2011-09-20 02:58:44 +00:00
$this -> view -> page = new Pagination ( $sum , $page , $limit );
}
function offlinelistAction ()
{
$page = ( int ) $this -> _request -> getParam ( 'page' );
if ( empty ( $page )) $page = 1 ;
$limit = 30 ;
$offset = $limit * ( $page - 1 );
2011-10-26 09:28:19 +00:00
$state = $this -> db -> query ( 'select count(*) from normalmetadata where datatype=1' );
2011-09-20 02:58:44 +00:00
$row = $state -> fetchAll ();
$sum = $row [ 0 ][ 'count' ];
2011-10-26 09:28:19 +00:00
$select = $this -> db -> select ();
$select -> from ( 'normalmetadata' , '*' ) -> where ( 'datatype=1' ) -> order ( 'title' ) -> limitPage ( $page , $limit );
$this -> view -> metadata = $this -> db -> fetchAll ( $select );
2011-09-20 02:58:44 +00:00
$this -> view -> page = new Pagination ( $sum , $page , $limit );
}
//展示最近20条离线神情记录情况
function offlineappAction ()
{
$sql = " select * from offlineapp where ts_approved is not null and pdflink<>'' and status>=0 order by ts_created desc limit 20 " ;
$this -> view -> rows = $this -> db -> fetchAll ( $sql );
}
function requestAction ()
{
}
function submitAction ()
{
}
function serviceAction ()
{
}
function newsletterAction ()
{
$l = new mydir ( $this -> view -> config -> paths -> newsletter , " newsletter_*.pdf " );
$this -> view -> newsletters = $l -> toArray ();
$this -> view -> addHelperPath ( 'helper' , 'Zend_View_Helper_' );
rsort ( $this -> view -> newsletters );
$form = new MaillistForm ();
$this -> view -> form = $form ;
$form -> submit -> setLabel ( '输入邮件地址,订阅数据通讯列表' );
if ( $this -> _request -> isPost ()) {
//发送邮件
$formData = $this -> _request -> getPost ();
if ( $form -> isValid ( $formData )) {
//$mail=new Zend_Mail('utf-8');
$mail = new WestdcMailer ( $this -> view -> config -> smtp );
$mail -> setFrom ( $formData [ 'email' ]);
$mail -> setBodyText ( " . " );
$mail -> setSubject ( 'subscribe' );
$mail -> addTo ( $this -> view -> config -> reportemail );
/*
$tr = new Zend_Mail_Transport_Smtp ( $this -> view -> config -> smtp -> host ,
array ( 'ssl' => $this -> view -> config -> smtp -> ssl ,
'auth' => $this -> view -> config -> smtp -> auth ,
'username' => $this -> view -> config -> smtp -> username ,
'password' => $this -> view -> config -> smtp -> password ));
$mail -> send ( $tr );
*/
$mail -> send ();
$this -> messenger -> addMessage ( '订阅成功,请检查您的邮件!' );
$this -> _redirect ( '/data/newsletter' );
}
} else {
$auth = Zend_Auth :: getInstance ();
if ( $auth -> hasIdentity ()) {
$user = $auth -> getIdentity ();
$formData [ 'email' ] = $user -> email ;
$form -> populate ( $formData );
}
}
}
function featureAction ()
{
$sql = " select * from datafeature order by id desc " ;
$this -> view -> feature = $this -> db -> fetchAll ( $sql );
}
function datasetcdAction ()
{
$cd = new DatasetcdTable ();
$this -> view -> rows = $cd -> fetchAll ();
}
/*
* 数据浏览
*/
function browseAction ()
{
$page = ( int ) $this -> _request -> getParam ( 'page' );
if ( empty ( $page )) $page = 1 ;
$limit = 10 ;
$offset = $limit * ( $page - 1 );
2011-10-26 09:28:19 +00:00
$state = $this -> db -> query ( 'select count(*) from metadata' );
2011-09-20 02:58:44 +00:00
$row = $state -> fetchAll ();
$sum = $row [ 0 ][ 'count' ];
2011-10-26 09:28:19 +00:00
$select = $this -> db -> select ();
2011-10-16 14:53:15 +00:00
$select -> from ( 'metadata' , '*' ) -> order ( 'id desc' ) -> limitPage ( $page , $limit );
2011-10-26 09:28:19 +00:00
$this -> view -> metadata = $this -> db -> fetchAll ( $select );
2011-09-20 02:58:44 +00:00
$this -> view -> page = new Pagination ( $sum , $page , $limit );
}
function tagAction ()
{
$id = ( int ) $this -> _request -> getParam ( 'id' );
2013-04-22 02:35:32 +00:00
$key = $this -> _request -> getParam ( 'key' );
2013-04-11 08:31:05 +00:00
$keytype = $this -> _request -> getParam ( 'keytype' );
2011-09-20 02:58:44 +00:00
$page = ( int ) $this -> _request -> getParam ( 'page' );
if ( empty ( $page )) $page = 1 ;
$limit = 10 ;
2013-04-22 02:35:32 +00:00
$offset = $limit * ( $page - 1 );
$sql = 'select keyword,count(*),keytype from keyword ' ;
if ( ! empty ( $keytype ) && ( $keytype == 'place' || $keytype == 'theme' || $keytype == 'discipline' || $keytype == 'temporal' )) $sql .= " where keytype=' " . $keytype . " ' " ;
2013-04-11 08:31:05 +00:00
$sql .= ' group by keyword,keytype order by keytype,keyword,count desc' ;
$state = $this -> db -> query ( $sql );
2011-09-20 02:58:44 +00:00
$this -> view -> keywords = $state -> fetchAll ();
2013-04-22 02:35:32 +00:00
2011-09-20 02:58:44 +00:00
if ( $id > 0 or ! empty ( $key )) {
if ( empty ( $key )) {
2011-10-26 09:28:19 +00:00
$where = $this -> db -> quoteInto ( 'id = ?' , $id );
2011-09-20 02:58:44 +00:00
$row = $md -> fetchRow ( $where );
$key = $row -> name ;
}
$this -> view -> codename = $key ;
2013-04-22 02:35:32 +00:00
$sql = $this -> db -> quoteInto ( 'select count(m.id) from normalmetadata m,keyword k where m.id=k.id and k.keyword=?' , $key );
2013-04-11 08:31:05 +00:00
2011-10-26 09:28:19 +00:00
$state = $this -> db -> query ( $sql );
2011-09-20 02:58:44 +00:00
$row = $state -> fetchAll ();
$sum = $row [ 0 ][ 'count' ];
2011-10-26 09:28:19 +00:00
$select = $this -> db -> select ();
$select -> from ( 'normalmetadata' , '*' ) -> join ( 'keyword' , 'normalmetadata.id=keyword.id' ) -> where ( 'keyword.keyword=?' , $key ) -> order ( 'normalmetadata.title' ) -> limitPage ( $page , $limit );
2011-09-20 02:58:44 +00:00
//$sql=$db->quoteInto('select m.* from metadata m,keyword k where m.id=k.id and k.keyword=?',$key);
//$state=$db->query($sql);
2011-10-26 09:28:19 +00:00
$this -> view -> metadata = $this -> db -> fetchAll ( $select );
2011-09-20 02:58:44 +00:00
$this -> view -> page = new Pagination ( $sum , $page , $limit );
}
}
/*
* 数据集序列浏览
*/
function seriesAction ()
{
$id = $this -> _request -> getParam ( 'id' );
if ( empty ( $id )) $id = 0 ;
if ( ! is_numeric ( $id ))
{
$name = $id ;
$id = '' ;
}
$keyword = $this -> _request -> getParam ( 'keyword' );
if ( empty ( $id )) {
if ( ! empty ( $name ))
{
2011-10-26 09:28:19 +00:00
$where = $this -> db -> quoteInto ( 'name = ?' , $name );
$row = $this -> db -> fetchRow ( " select * from series where " . $where );
2011-09-20 02:58:44 +00:00
}
} else {
2011-10-26 09:28:19 +00:00
$where = $this -> db -> quoteInto ( 'id = ?' , $id );
$row = $this -> db -> fetchRow ( " select * from series where " . $where );
2011-09-20 02:58:44 +00:00
}
if ( ! empty ( $id ) or ! empty ( $name ))
{
if ( ! $row ) $this -> _redirect ( '/data' );
2011-10-26 09:28:19 +00:00
$id = $row [ 'id' ];
2011-09-20 02:58:44 +00:00
}
$page = ( int ) $this -> _request -> getParam ( 'page' );
if ( empty ( $page )) $page = 1 ;
$limit = 10 ;
$offset = $limit * ( $page - 1 );
2011-10-26 09:28:19 +00:00
$state = $this -> db -> query ( 'select s.id,name,count(*) from series s,dataseries d where d.sid=s.id group by s.id,s.name' );
2011-09-20 02:58:44 +00:00
$this -> view -> serie = $state -> fetchAll ();
if ( $id > 0 ) {
2011-10-26 09:28:19 +00:00
//$where=$this->db->quoteInto('id = ?',$id);
//$row=$this->db->fetchRow("select * from series where ".$where);
$this -> view -> codename = $row [ 'name' ];
2011-09-20 02:58:44 +00:00
if ( ! empty ( $keyword ))
{
2011-10-26 09:28:19 +00:00
$sql = 'select count(m.id) as count from normalmetadata m,dataseries d,keyword k where m.id=d.id and m.id=k.id and d.sid=? and k.keyword=?' ;
2011-10-27 07:36:10 +00:00
$row = $this -> db -> fetchAll ( $sql , array ( $id , $keyword ));
2011-10-26 09:28:19 +00:00
$this -> view -> codename .= " 【关键词: " . $keyword . " 】 " ;
2011-09-20 02:58:44 +00:00
} else {
2011-10-26 09:28:19 +00:00
$sql = 'select count(m.id) as count from normalmetadata m,dataseries d where m.id=d.id and d.sid=?' ;
$row = $this -> db -> fetchAll ( $sql , array ( $id ));
2011-09-20 02:58:44 +00:00
}
$sum = $row [ 0 ][ 'count' ];
2011-10-26 09:28:19 +00:00
$select = $this -> db -> select ();
$select -> from ( 'normalmetadata' , '*' ) -> join ( 'dataseries' , 'normalmetadata.id=dataseries.id' ) -> where ( 'dataseries.sid=?' , $id ) -> order ( 'normalmetadata.title' ) -> limitPage ( $page , $limit );
if ( ! empty ( $keyword )) $select -> join ( 'keyword' , 'keyword.id=normalmetadata.id' ) -> where ( 'keyword.keyword=?' , $keyword );
$this -> view -> metadata = $this -> db -> fetchAll ( $select );
2011-09-20 02:58:44 +00:00
$this -> view -> page = new Pagination ( $sum , $page , $limit );
2011-10-26 09:28:19 +00:00
//$this->view->showtools=($sum>$page)?true:false;
//$this->view->form=new SearchForm();
$sql = $this -> db -> quoteInto ( " select keyword,count(*) as count from (select t.keyword,t.id from keyword t left join dataseries d on t.id=d.id where t.keytype='place' and d.sid=?) as f group by keyword order by count desc limit 30 " , $id );
$state = $this -> db -> query ( $sql );
2011-09-20 02:58:44 +00:00
$row = $state -> fetchAll ();
$this -> view -> places = $row ;
$this -> view -> seriesid = $id ;
} else {
//提供全部数据集序列列表
}
}
/*
* 分类浏览模式
*/
function categoryAction ()
{
2011-09-28 09:55:52 +00:00
$page = $this -> _request -> getParam ( 'page' );
2011-09-20 02:58:44 +00:00
$code = ( int ) $this -> _request -> getParam ( 'code' );
2011-10-26 09:28:19 +00:00
$state = $this -> db -> query ( 'select c.code,name,name_zh,count(*) from category c,categorycode cc where c.code=cc.code group by c.code,cc.name,cc.name_zh' );
2011-09-20 02:58:44 +00:00
$this -> view -> category = $state -> fetchAll ();
if ( $code > 0 && $code < 20 ) {
2011-10-26 09:28:19 +00:00
$where = $this -> db -> quoteInto ( 'code = ?' , $code );
$row = $this -> db -> fetchRow ( " select * from categorycode where " . $where );
2011-10-27 07:36:10 +00:00
$this -> view -> codename = ( empty ( $row [ 'name_zh' ]) ? $row [ 'name' ] : $row [ 'name_zh' ]);
$sql = 'select count(m.id) from normalmetadata m left join category c on m.id=c.id where c.code=?' ;
$row = $this -> db -> fetchRow ( $sql , array ( $code ));
$sum = $row [ 'count' ];
$select = $this -> db -> select ();
$select -> from ( 'normalmetadata as m' , '*' ) -> joinLeft ( 'category as c' , 'm.id=c.id' ) -> where ( 'c.code=?' , $code ) -> order ( 'm.title' ) -> limitPage ( $page , $this -> limit );
$this -> view -> metadata = $this -> db -> fetchAll ( $select );
2011-10-26 09:28:19 +00:00
$this -> view -> page = new Pagination ( $sum , $page , $this -> limit );
2011-09-20 02:58:44 +00:00
} else {
//提供全部分类列表
}
}
/*
* 时间浏览方式
* todo : 实现xml的缓存, 基于时间的缓存( 每天) ? 基于元数据修改的缓存, 每次导入后都重新生成一次。
*/
function timelineAction ()
{
$fn = " time1.xml " ;
2011-10-26 09:28:19 +00:00
$rows = $this -> db -> fetchAll ( " select ts_created from normalmetadata order by ts_created desc limit 1 " );
2011-09-20 02:58:44 +00:00
$last_update = strtotime ( $rows [ 0 ][ 'ts_created' ]);
if ( ! file_exists ( $fn ) || ( filemtime ( $fn ) < $last_update ))
{
$dateformat = " M j Y " ;
$md = new MetadataTable ();
$db = $md -> getAdapter ();
2011-10-26 09:28:19 +00:00
$state = $db -> query ( 'select id,uuid,description,title,timebegin,timeend from normalmetadata where timebegin is not null order by timebegin' );
2011-09-20 02:58:44 +00:00
$rows = $state -> fetchAll ();
$timexml = '<data>' ;
foreach ( $rows as $row ) {
$timexml .= '<event start="' . date ( $dateformat , strtotime ( $row [ 'timebegin' ])) . '" ' ;
if ( $row [ 'timeend' ] != '' && $row [ 'timeend' ] != $row [ 'timebegin' ]) $timexml .= ' end="' . date ( $dateformat , strtotime ( $row [ 'timeend' ])) . '" isDuration="true"' ;
$timexml .= ' title="' . htmlspecialchars ( $row [ 'title' ]) . '" image="/images/westdc_40w.gif" link="/data/' . $row [ 'uuid' ] . '">' ;
$desc_length = mb_strlen ( $row [ 'description' ], " UTF-8 " );
$desc = mb_substr ( $row [ 'description' ], 0 ,( $desc_length > 300 ) ? 300 : $desc_length , " UTF-8 " );
if ( $desc_length > 300 ) $desc .= " ... " ;
$timexml .= htmlspecialchars ( $desc );
$timexml .= " </event> \n " ;
}
$timexml .= '</data>' ;
$fp = fopen ( $fn , 'w' );
fwrite ( $fp , $timexml );
fclose ( $fp );
}
//$this->_helper->layout->disableLayout();
}
/*
* todo : 空间浏览
*/
function mapAction ()
{
//use json & openlayers?
$id = ( int ) $this -> _request -> getParam ( 'id' );
if ( $id > 0 ) $this -> view -> params = " /id/ $id " ;
}
/*
* 产生geojson数据
*/
function jsonAction ()
{
$md = new MetadataTable ();
$db = $md -> getAdapter ();
$id = ( int ) $this -> _request -> getParam ( 'id' );
$where = '' ;
if ( ! empty ( $id )) { $where = ' where id=' . $id ; }
2011-10-26 09:28:19 +00:00
$sql = 'select id,uuid,west,south,north,east,title from normalmetadata' . $where ;
2011-09-20 02:58:44 +00:00
$state = $db -> query ( $sql );
$rows = $state -> fetchAll ();
$geomd = new GeoMetaData ();
foreach ( $rows as $row ){
if ( $id )
$box = new GeoBox ( $row [ 'west' ], $row [ 'south' ], $row [ 'east' ], $row [ 'north' ]);
else
$box = new GeoBoxLine ( $row [ 'west' ], $row [ 'south' ], $row [ 'east' ], $row [ 'north' ]);
$feature = new Geofeature ();
$feature -> id = $row [ 'id' ];
$feature -> addProperties ( 'title' , $row [ 'title' ]);
$feature -> addProperties ( 'uuid' , $row [ 'uuid' ]);
$feature -> addProperties ( 'id' , $row [ 'id' ]);
$feature -> geometry = $box ;
$geomd -> addFeature ( $feature );
}
$this -> _helper -> json ( $geomd );
}
/*
* 时空动态浏览
*/
function timemapAction ()
{
2011-10-26 09:28:19 +00:00
$sql = 'select id,uuid,west,south,north,east,title,timebegin,timeend from normalmetadata where timebegin is not null' ;
2011-09-20 02:58:44 +00:00
$this -> view -> rows = $this -> db -> fetchAll ( $sql );
}
/*
* 返回XML源文件
*/
function xmlAction ()
{
$uuid = $this -> _request -> getParam ( 'uuid' );
$row = $this -> db -> fetchRow ( " select xml.data from xml left join metadata on xml.id=metadata.id where metadata.uuid=? " , array ( $uuid ));
$this -> _helper -> layout -> disableLayout ();
$this -> _helper -> viewRenderer -> setNoRender ();
$this -> getResponse () -> setHeader ( 'Content-Type' , 'text/xml' )
-> setBody ( $row [ 'data' ]);
}
function detailAction ()
{
$id = ( int ) $this -> _request -> getParam ( 'id' );
$xml = new XmlTable ();
$db = $xml -> getAdapter ();
$where = $db -> quoteInto ( 'id=?' , $id );
$order = 'id desc' ;
$row = $xml -> fetchRow ( $where , $order );
// Load the XML source
$xml = new DOMDocument ;
$xml -> loadXML ( $row -> data );
$xsl = new DOMDocument ;
$xsl -> load ( $this -> view -> config -> westdc -> xsl );
// Configure the transformer
$proc = new XSLTProcessor ;
$proc -> importStyleSheet ( $xsl ); // attach the xsl rules
$this -> view -> xml = $proc -> transformToXML ( $xml );
//$this->_helper->layout->disableLayout();
//$this->_helper->viewRenderer->setNoRender();
//$this->getResponse()->setHeader('Content-Type', 'text/html')
// ->setBody($proc->transformToXML($xml));
}
function feedAction ()
{
$feedArray = array (
'title' => '中国西部环境与生态科学数据中心' ,
'link' => 'http://' . $_SERVER [ 'SERVER_NAME' ] . '/data/feed' ,
'description' => '共享西部计划产生的数据' ,
'language' => 'zh-CN' ,
'charset' => 'utf-8' ,
'published' => time (),
//'generator' => 'Zend Framework Zend_Feed',
'entries' => array ()
);
2011-10-26 09:28:19 +00:00
$sql = " select * from normalmetadata order by ts_created desc " ;
2011-09-20 02:58:44 +00:00
$rs = $this -> db -> fetchAll ( $sql );
$feedArray [ 'published' ] = strtotime ( $rs [ 0 ][ 'ts_created' ]);
foreach ( $rs as $r )
{
$feedArray [ 'entries' ][] = array (
'title' => $r [ 'title' ],
'link' => 'http://' . $_SERVER [ 'SERVER_NAME' ] . '/data/' . $r [ 'uuid' ],
'guid' => 'http://' . $_SERVER [ 'SERVER_NAME' ] . '/data/' . $r [ 'uuid' ],
//'content'=>$r['description'],
'description' => $r [ 'description' ],
'lastUpdate' => strtotime ( $r [ 'ts_created' ])
);
}
$feed = Zend_Feed :: importArray ( $feedArray , 'rss' );
$this -> _helper -> layout -> disableLayout ();
$this -> _helper -> viewRenderer -> setNoRender ();
$feed -> send ();
}
/*
* todo : search
*/
function searchAction ()
{
$this -> view -> addHelperPath ( 'helper' , 'Zend_View_Helper_' );
$form = new SearchForm ();
$this -> view -> form = $form ;
//$form->submit->setLabel('快速搜索');
$key = $this -> _request -> getParam ( 'q' );
if ( ! empty ( $key )) {
//$formData=$this->_request->getPost();
//include_once("bcspamblock.php");
//if ($form->isValid($formData)) {
$page =@ ( int ) $this -> _request -> getParam ( 'page' );
if ( empty ( $page )) $page = 1 ;
$offset = $this -> limit * ( $page - 1 );
$search = new Search ( $key );
$where = $search -> sql_expr ( array ( " title " , " description " ));
2011-10-26 09:28:19 +00:00
$row = $this -> db -> fetchAll ( " select count(*) from normalmetadata where " . $where );
2011-09-20 02:58:44 +00:00
$sum = $row [ 0 ][ 'count' ];
2011-10-26 09:28:19 +00:00
$sql = " select uuid,title,id,description from normalmetadata where " . $where . " order by title limit ? offset ? " ;
2011-09-20 02:58:44 +00:00
$this -> view -> metadata = $this -> db -> fetchAll ( $sql , array ( $this -> limit , $offset ));
$this -> view -> page = new Pagination ( $sum , $page , $this -> limit );
$this -> view -> key = $key ;
}
}
/*
* todo : 高级搜索
*/
function advancesearchAction ()
{
$this -> view -> addHelperPath ( 'helper' , 'Zend_View_Helper_' );
//$form=new SearchForm();
//$this->view->form=$form;
$md = new MetadataTable ();
$db = $md -> getAdapter ();
$page = ( int ) $this -> _request -> getParam ( 'page' );
if ( empty ( $page )) $page = 1 ;
$limit = 10 ;
$offset = $limit * ( $page - 1 );
$key = $this -> _request -> getParam ( 'q' );
$n = ( int ) $this -> _request -> getParam ( 'n' );
$s = ( int ) $this -> _request -> getParam ( 's' );
$e = ( int ) $this -> _request -> getParam ( 'e' );
$w = ( int ) $this -> _request -> getParam ( 'w' );
if ( ! ( empty ( $n ) && empty ( $key ))) {
if ( empty ( $n )) $n = 90 ;
if ( empty ( $s )) $s =- 90 ;
if ( empty ( $e )) $e = 180 ;
if ( empty ( $w )) $w =- 180 ;
$start = $this -> _request -> getParam ( 'start' );
$end = $this -> _request -> getParam ( 'end' );
if ( ! empty ( $key )) {
2011-10-26 09:28:19 +00:00
$sql = 'select count(*) from normalmetadata where east<? and west>? and north<? and south>? and (title ilike ? or description ilike ?)' ;
2011-09-20 02:58:44 +00:00
$row = $db -> fetchAll ( $sql , array ( $e , $w , $n , $s , '%' . $key . '%' , '%' . $key . '%' ));
} else {
2011-10-26 09:28:19 +00:00
$sql = 'select count(*) from normalmetadata where east<? and west>? and north<? and south>?' ;
2011-09-20 02:58:44 +00:00
$row = $db -> fetchAll ( $sql , array ( $e , $w , $n , $s ));
}
$sum = $row [ 0 ][ 'count' ];
$select = $db -> select ();
2011-10-26 09:28:19 +00:00
$select -> from ( 'normalmetadata' , '*' ) -> where ( 'east<?' , $e ) -> where ( 'west>?' , $w ) -> where ( 'north<?' , $n ) -> where ( 'south>?' , $s );
2011-09-20 02:58:44 +00:00
if ( ! empty ( $key )) $select -> where ( '(title ilike ? or description ilike ?)' , '%' . $key . '%' );
$select -> order ( 'title' ) -> limit ( $limit , $offset );
$this -> view -> metadata = $db -> fetchAll ( $select );
$this -> view -> page = new Pagination ( $sum , $page );
$this -> view -> key = $key ;
}
}
/*
* 根据id或uuid来查看元数据
* id为一组数字, uuid为唯一标识符
*/
2012-06-13 04:05:33 +00:00
function viewAction ()
2011-09-20 02:58:44 +00:00
{
2011-10-27 07:36:10 +00:00
$id = ( int ) $this -> _request -> getParam ( 'id' );
2013-05-08 05:47:28 +00:00
$sql = " select m.*,s.status,g.id as gid,t.filename,i.doi as datadoi,i.authors,i.author_en,i.publisher,i.publisher_en, date_part('year',i.ts_published) as publish_year from normalmetadata m left join mdstatus s on m.uuid=s.uuid
left join thumbnail t on t . id = m . id left join geonetworkmetadata g on m . uuid = g . uuid left join datadoi i on i . uuid = m . uuid where " ;
2011-09-20 02:58:44 +00:00
if ( empty ( $id )) {
$uuid = $this -> _request -> getParam ( 'uuid' );
if ( empty ( $uuid )) $this -> _redirect ( '/data' );
2011-10-24 12:30:39 +00:00
$where = $this -> db -> quoteInto ( 'm.uuid = ?' , $uuid );
2011-09-20 02:58:44 +00:00
} else {
2011-10-24 12:30:39 +00:00
$where = $this -> db -> quoteInto ( 'm.id = ?' , $id );
2011-10-27 07:36:10 +00:00
}
$sql .= $where ;
$this -> db -> setFetchMode ( Zend_Db :: FETCH_OBJ );
2011-10-24 12:30:39 +00:00
$row = $this -> db -> fetchRow ( $sql );
2011-09-20 02:58:44 +00:00
if ( ! $row ) $this -> _redirect ( '/data' );
$id = $row -> id ;
$uuid = $row -> uuid ;
$this -> view -> metadata = $row ;
2011-10-27 07:36:10 +00:00
//提前对表格进行预处理
2011-10-16 15:24:10 +00:00
$wiki = new WikiFormat ();
$this -> view -> metadata -> description = $wiki -> parseTable ( $this -> view -> escape ( $row -> description ));
2011-09-20 02:58:44 +00:00
//处理外部链接
2011-10-27 07:36:10 +00:00
$this -> view -> metadata -> description = preg_replace ( '/\[\s*(http:\/\/.+?)\s+(.*?)\]/m' , '<a href="$1">$2</a>' , $this -> view -> metadata -> description );
2011-11-24 07:53:13 +00:00
$this -> view -> thumburl = '/gndata/' . sprintf ( '%05d' , floor (( $row -> gid + 0.1 ) / 100 ) * 100 ) . '-' . sprintf ( '%05d' , ceil (( $row -> gid + 0.1 ) / 100 ) * 100 - 1 ) . " / " . $row -> gid ;
2011-10-24 12:30:39 +00:00
$this -> view -> thumburl .= '/public/' . str_replace ( '_s.' , '.' , $row -> filename );
2011-09-20 02:58:44 +00:00
if ( is_numeric ( $row -> projection ))
{
$sql = " select proj4text from spatial_ref_sys where auth_srid=? " ;
2011-10-24 12:30:39 +00:00
$rs = $this -> db -> fetchRow ( $sql , array (( int ) $row -> projection ));
if ( $rs ) $this -> view -> projection = $rs -> proj4text ;
2011-09-20 02:58:44 +00:00
}
2013-03-22 03:47:41 +00:00
$sql = " select * from keyword where id=? order by keytype,ts_created " ;
$sth = $this -> db -> prepare ( $sql );
$rs = $sth -> execute ( array ( $id ));
$this -> view -> keys = $sth -> fetchAll ( PDO :: FETCH_BOTH );
2011-09-20 02:58:44 +00:00
$sql = 'select c.code,cc.name,cc.name_zh from category c,categorycode cc where c.code=cc.code and c.id= ?' ;
2011-10-24 12:30:39 +00:00
$state = $this -> db -> query ( $sql , array ( $id ));
2011-09-20 02:58:44 +00:00
$this -> view -> category = $state -> fetchAll ();
$sql = 'select s.name,s.id from dataseries d, series s where d.sid=s.id and d.id= ?' ;
2011-10-24 12:30:39 +00:00
$state = $this -> db -> query ( $sql , array ( $id ));
2011-09-20 02:58:44 +00:00
$this -> view -> series = $state -> fetchAll ();
2011-10-24 12:30:39 +00:00
$sql = $this -> db -> quoteInto ( " select count(*) as count from dataorder where uuid=? " , $uuid );
$row = $this -> db -> fetchRow ( $sql );
$this -> view -> downloaded = $row -> count ;
2011-09-20 02:58:44 +00:00
//update the viewed times
$sql = " update mdstat set viewed=viewed+1 where uuid=? " ;
2011-10-24 12:30:39 +00:00
$this -> db -> query ( $sql , array ( $uuid ));
$sql = $this -> db -> quoteInto ( " select viewed from mdstat where uuid=? " , $uuid );
$row = $this -> db -> fetchRow ( $sql );
$this -> view -> viewed = $row -> viewed ;
2011-09-20 02:58:44 +00:00
//数据文档
$sql = " select linkage from onlineresource where uuid=? and description='数据说明文档' " ;
2011-10-24 12:30:39 +00:00
$sql = $this -> db -> quoteInto ( $sql , $uuid );
$row = $this -> db -> fetchRow ( $sql );
if ( $row ) $this -> view -> doc = $row -> linkage ;
2011-09-20 02:58:44 +00:00
//相关资源
2011-11-26 14:44:39 +00:00
$sql = " select * from onlineresource where uuid=? and (linkage not like '%ftp.westgis%') and name<>'元数据地址' " ;
2011-10-24 12:30:39 +00:00
$sql = $this -> db -> quoteInto ( $sql , $uuid );
$this -> view -> resources = $this -> db -> fetchAll ( $sql );
2011-09-20 02:58:44 +00:00
//建议参考文献
2013-05-08 03:35:00 +00:00
$sql = " select r.* from reference r left join mdref m on m.refid=r.id where m.uuid=? and m.reftype=0 order by m.place " ;
2011-10-24 12:30:39 +00:00
$sql = $this -> db -> quoteInto ( $sql , $uuid );
2012-06-06 08:19:56 +00:00
$this -> view -> ref = $this -> db -> fetchAll ( $sql );
2012-05-19 14:15:10 +00:00
//用户发表文献
$sql = " select r.* from reference r left join mdref m on m.refid=r.id where m.uuid=? and m.reftype=1 " ;
$sql = $this -> db -> quoteInto ( $sql , $uuid );
2012-06-06 08:19:56 +00:00
$this -> view -> userref = $this -> db -> fetchAll ( $sql );
2011-09-20 02:58:44 +00:00
//相关用户
$sql = " select p.email,p.individual,p.organisation,r.role from role r left join responsible p on r.resid=p.id where r.uuid=? order by r.role,r.id " ;
2011-10-24 12:30:39 +00:00
$this -> view -> authors = $this -> db -> fetchAll ( $sql , array ( $uuid ));
2011-09-20 02:58:44 +00:00
//数据限制信息
$sql = " select u.* from uselimit u left join mdlimit m on u.id=m.lid where m.uuid=? " ;
2011-10-24 12:30:39 +00:00
$this -> view -> uselimits = $this -> db -> fetchAll ( $sql , array ( $uuid ));
2011-12-02 03:04:10 +00:00
//相关下载
$sql = " select d.uuid,count(distinct(d.userid)) as downtimes,m.title from dataorder d left join metadata m on d.uuid=m.uuid where d.userid in (
select distinct ( userid ) from dataorder where uuid = ? and status in ( 0 , 5 )
) and d . uuid <> ? and length ( m . title ) > 2 group by d . uuid , m . title order by count ( distinct ( d . userid )) desc limit 10 ; " ;
$this -> view -> downlists = $this -> db -> fetchAll ( $sql , array ( $uuid , $uuid ));
2011-11-24 07:44:14 +00:00
//相关文献
$sql = " select a.*,array_to_string(array(select author from knl_author t where t.item_id=a.item_id order by place asc),'; ') as author from knl_article a where ( " ;
foreach ( $this -> view -> keys as $k )
{
2013-03-22 03:47:41 +00:00
if ( $k [ 'keytype' ] == 'theme' )
2011-11-24 07:44:14 +00:00
{
2013-03-22 03:47:41 +00:00
$sql .= " a.title like '% " . $k [ 'keyword' ] . " %' or " ;
2011-11-24 07:44:14 +00:00
}
}
$sql .= " 1<>1) order by a.ts_created desc limit 10 " ;
2011-11-24 07:45:55 +00:00
$this -> view -> literature = $this -> db -> fetchAll ( $sql );
//相关元数据,根据同名关键词实现
$sql = " select distinct(md.uuid),md.title from keyword kw left join normalmetadata md on kw.id=md.id where kw.keyword in (select k.keyword from keyword k left join metadata m on k.id=m.id where m.id=? and k.keytype='theme') and kw.id<>? limit 10 " ;
$this -> view -> related = $this -> db -> fetchAll ( $sql , array ( $id , $id ));
2011-11-24 09:31:55 +00:00
//用户下载记录
2011-12-29 08:09:58 +00:00
$sql = " select o.ts_created,m.uuid,u.realname,u.unit,oa.project as onlineproject, fa.project as offlineproject
from dataorder as o left join metadata as m on o . uuid = m . uuid left join users as u on o . userid = u . id
left join onlineapp oa on o . onlineappid = oa . id left join offlineapp fa on o . offlineappid = fa . id
2011-12-03 07:47:04 +00:00
where m . uuid = '$uuid' and ( o . status = 0 or o . status = 5 ) and u . realname IS NOT NULL order by o . ts_created desc limit 10 " ;
2011-11-24 09:31:55 +00:00
$this -> view -> downhistory = $this -> db -> fetchAll ( $sql );
2011-09-30 08:48:49 +00:00
//数据附件
2011-11-08 04:16:56 +00:00
$sql = $this -> db -> quoteInto ( " select m.id,a.realname from mdattach m left join attachments a on m.id=a.id where m.uuid=? " , $uuid );
$this -> view -> attachments = $this -> db -> fetchAll ( $sql );
2012-06-13 04:05:33 +00:00
//数据版本
$sql = " SELECT count(id) as c FROM mdversion WHERE uuid=? AND changelog IS NOT NULL " ;
$sth = $this -> db -> prepare ( $sql );
$sth -> execute ( array ( $uuid ));
$row = $sth -> fetch ();
$this -> view -> version = $row ;
2012-12-12 09:08:34 +00:00
$archives = new Archive ( $this -> db );
$data_archives = $archives -> getArchiveByUUID ( $uuid );
if ( ! empty ( $data_archives ))
{
foreach ( $data_archives as $k => $v )
{
$data_archives [ $k ][ 'url' ] = $archives -> getArchiveUrlByCid ( $v [ 'id' ]);
}
}
$this -> view -> data_archives = $data_archives ;
2013-04-22 02:35:32 +00:00
//支持项目
include_once ( " data/Fund.php " );
$fund = new Fund ( $this -> db );
$this -> view -> fund = $fund -> fetch ( $uuid );
2012-12-12 09:08:34 +00:00
2011-11-16 10:14:50 +00:00
//自动跳转
$sql = " select s.* from datasource d left join source s on d.sourceid=s.id where d.uuid=? " ;
$row = $this -> db -> fetchRow ( $this -> db -> quoteInto ( $sql , $uuid ));
2012-05-18 01:03:05 +00:00
$jump = $this -> _request -> getParam ( 'jump' );
if ( $jump == " " ) $jump = 1 ; //默认跳转
2012-05-17 12:47:00 +00:00
if ( @ $row -> has_pages && ( $jump == 1 ))
2011-11-23 07:52:49 +00:00
{
2011-11-16 10:14:50 +00:00
$this -> _helper -> viewRenderer ( $row -> code . '/view' , null , true );
2011-11-08 04:16:56 +00:00
}
2011-11-24 07:44:14 +00:00
} //viewAction
2011-11-23 07:52:49 +00:00
2012-06-13 04:05:33 +00:00
/*
getversionAction () 获取数据版本
*/
function getversionAction (){
$ac = $this -> _getParam ( 'ac' );
$uuid = $this -> _getParam ( 'uuid' );
if ( $ac == 'list' )
{
$this -> _helper -> layout -> disableLayout ();
$this -> _helper -> viewRenderer -> setNoRender ();
$sql = " SELECT v.changelog,v.ts_created,u.username FROM mdversion v
LEFT JOIN users u ON v . userid = u . id
WHERE v . uuid = ? AND v . changelog IS NOT NULL
ORDER BY v . ts_created DESC " ;
$sth = $this -> db -> prepare ( $sql );
$sth -> execute ( array ( $uuid ));
$rows = $sth -> fetchAll ();
if ( $rows )
{
foreach ( $rows as $k => $v )
{
$rows [ $k ][ 'ts_created' ] = date ( " Y-m-d H:i " , strtotime ( $v [ 'ts_created' ]));
2012-06-13 07:16:32 +00:00
$rows [ $k ][ 'changelog' ] = str_replace ( " \n " , " </p><p> " , $v [ 'changelog' ]);
2012-06-13 04:05:33 +00:00
}
$data = array ( " list " => $rows );
$this -> jsonexit ( $data );
return true ;
} else {
$data = array ( " error " => " 处理中出现错误 " );
$this -> jsonexit ( $data );
return true ;
}
}
} //getversionAction()
2011-11-23 07:52:49 +00:00
function replace ( $string ){
$patterns = array ( " / \" /i " , " / \ '/i " );
$replacements = array ( " “ " , " ‘ " );
ksort ( $patterns );
ksort ( $replacements );
return preg_replace ( $patterns , $replacements , $string );
2011-11-24 03:27:25 +00:00
} //引号替换
2011-11-23 07:52:49 +00:00
function postcommentAction (){
$this -> _helper -> layout -> disableLayout ();
$this -> _helper -> viewRenderer -> setNoRender ();
try {
$auth = Zend_Auth :: getInstance ();
if ( $auth -> hasIdentity ())
{
$user = $auth -> getIdentity ();
$userid = $user -> id ;
} else
{
$userid = 0 ;
}
$author = mb_substr ( $this -> replace ( trim ( $this -> _request -> getParam ( 'author' ))), 0 , 30 , 'UTF-8' );
$email = mb_substr ( $this -> replace ( trim ( $this -> _request -> getParam ( 'email' ))), 0 , 60 , 'UTF-8' );
$url = mb_substr ( $this -> replace ( trim ( $this -> _request -> getParam ( 'url' ))), 0 , 60 , 'UTF-8' );
$content = $this -> replace ( trim ( $this -> _request -> getParam ( 'content' )));
2011-12-29 08:09:58 +00:00
$vdcode = mb_substr ( $this -> replace ( trim ( $this -> _request -> getParam ( 'vdcode' ))), 0 , 4 , 'UTF-8' );
if ( empty ( $author ))
{
echo " 请输入您的名字 " ;
exit ();
}
2011-11-23 07:52:49 +00:00
if ( strlen ( $author ) < 3 ) exit ( " 姓名长度不得少于2个汉字 :) " );
2011-12-29 08:09:58 +00:00
if ( empty ( $email ))
{
echo " 请输入您的电子邮箱地址 " ;
exit ();
}
2011-11-23 07:52:49 +00:00
if ( strlen ( $email ) < 4 ) exit ( " Email长度太短, 请填写正确的Email :) " );
if ( ! preg_match ( " / \ w+([-+.] \ w+)*@ \ w+([-.] \ w+)* \ . \ w+([-.] \ w+)*/i " , $email ))
{
echo " Email格式不正确 " ;
exit ();
}
2011-12-29 08:09:58 +00:00
if ( strlen ( $content ) < 5 ) exit ( " 评论长度不得少于3个汉字 :) " );
if ( preg_match ( " /script/i " , $content ))
{
$content = preg_replace ( " /script/i " , " s c r i p t " , $content );
}
if ( preg_match ( " /<|>/ " , $content ))
{
$data = array (
'<' => '<' ,
'>' => '>' ,
);
2011-11-23 08:12:29 +00:00
2011-12-29 08:09:58 +00:00
$patterns = array ();
$replacements = array ();
foreach ( $data as $k => $v )
{
$patterns [] = '/' . $k . '/i' ;
$replacements [] = $v ;
}
ksort ( $patterns );
ksort ( $replacements );
$content = preg_replace ( $patterns , $replacements , $content );
if ( ! empty ( $url ))
{
$url = preg_replace ( $patterns , $replacements , $url );
}
}
2011-11-23 08:12:29 +00:00
if ( preg_match ( " /script/i " , $url ))
{
$url = preg_replace ( " /script/i " , " s c r i p t " , $url );
}
2011-11-23 07:52:49 +00:00
2011-12-29 08:09:58 +00:00
if ( ! preg_match ( " /http: \ / \ // " , $url ))
2011-11-23 08:12:29 +00:00
{
2011-12-29 08:09:58 +00:00
$url = " http:// " . $url ;
2011-11-23 08:12:29 +00:00
}
2011-11-23 07:52:49 +00:00
$uuid = trim ( $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 ))
{
2011-12-29 08:09:58 +00:00
echo " 参数错误! " ;
exit ();
}
if ( strtolower ( $vdcode ) != $_SESSION [ 'vdcodes' ])
{
echo " 验证码错误,请重新输入 " ;
2011-11-23 07:52:49 +00:00
exit ();
}
2011-12-29 08:09:58 +00:00
2011-11-23 07:52:49 +00:00
$data = array (
'uuid' => $uuid ,
'uid' => $userid ,
'author' => $author ,
'email' => $email ,
'url' => $url ,
'ip' => $_SERVER [ 'REMOTE_ADDR' ],
'content' => $content ,
'agent' => $_SERVER [ 'HTTP_USER_AGENT' ],
'type' => 'comment'
);
$sql = " INSERT INTO comments (author,email,url,ip,content,agent,type,uuid,userid) VALUES (?,?,?,?,?,?,?,?,?) " ;
$sth = $this -> db -> prepare ( $sql );
$exec = $sth -> execute ( array ( $data [ 'author' ], $data [ 'email' ], $data [ 'url' ], $data [ 'ip' ], $data [ 'content' ], $data [ 'agent' ], $data [ 'type' ], $data [ 'uuid' ], $data [ 'uid' ]));
if ( $exec )
{
2012-12-06 07:33:19 +00:00
$sql = " SELECT u.email FROM mdauthor au
LEFT JOIN users u on au . userid = u . id
WHERE au . uuid = '$uuid' " ;
$sth = $this -> db -> query ( $sql );
$rows = $sth -> fetchAll ();
2012-01-06 08:44:54 +00:00
@ $mailtp = new EmailText (
$this -> db ,
2012-01-06 09:10:51 +00:00
'data-comment-note' ,
2012-01-06 08:44:54 +00:00
array (
2012-01-06 09:10:51 +00:00
'user' => $user -> username ,
2012-01-06 08:44:54 +00:00
'uuid' => $data [ 'uuid' ],
2012-06-06 08:19:56 +00:00
'title' => $this -> replace ( trim ( $this -> _request -> getParam ( 'mdtitle' ))),
2012-01-15 01:37:23 +00:00
'content' => $content
2012-01-06 08:44:54 +00:00
)
);
@ $mail = new WestdcMailer ( $this -> view -> config -> smtp );
@ $mail -> setBodyText ( $mailtp -> getBody ());
2012-01-06 09:10:51 +00:00
@ $mail -> setFrom ( $this -> view -> config -> service -> email , '西部数据中心服务组' );
2012-01-06 08:44:54 +00:00
@ $mail -> addTo ( $this -> view -> config -> service -> email );
2012-12-06 07:33:19 +00:00
if ( is_array ( $rows ) && count ( $rows ) > 0 )
{
foreach ( $rows as $v )
{
@ $mail -> addTo ( $v [ 'email' ]);
}
}
2012-01-06 08:44:54 +00:00
@ $mail -> setSubject ( $mailtp -> getSubject ());
@ $mail -> send ();
2011-11-23 07:52:49 +00:00
$msg = " 用户 " . $user -> username . " 对元数据《 " . $this -> replace ( trim ( $this -> _request -> getParam ( 'mdtitle' ))) . " 》进行了评论,<a href= \" /admin/data/comment \" >点击查看</a> " ;
include_once ( " message.php " );
message :: post ( $this -> db , 0 , - 1 , " 收到新数据评论 " , $msg );
2011-12-29 08:09:58 +00:00
echo " 评论成功<script> $ ('#reset').click();ajaxpage(0); $ ('#imgcode').click();</script> " ;
2011-11-23 07:52:49 +00:00
exit ();
} else
{
echo " 评论失败,请重试 :) " ;
exit ();
}
} catch ( Exception $e ){
echo " 出错了,请稍后再试 " ;
exit ();
}
2011-11-24 03:27:25 +00:00
} //ajax评论
2011-09-20 02:58:44 +00:00
/*
* 数据评论, 根据UUID读取
*/
function commentAction ()
{
$this -> _helper -> layout -> disableLayout ();
$this -> _helper -> viewRenderer -> setNoRender ();
$uuid = $this -> _request -> getParam ( 'uuid' );
if ( empty ( $uuid )) die ();
2012-09-18 09:14:41 +00:00
$sql = " select * from comments where uuid=? AND reply=0 order by id desc " ;
2011-09-20 02:58:44 +00:00
$comments = $this -> db -> fetchAll ( $sql , array ( $uuid ));
2011-10-28 03:18:44 +00:00
$paginator = Zend_Paginator :: factory ( $comments );
$paginator -> setCurrentPageNumber ( $this -> _getParam ( 'page' ));
$paginator -> setItemCountPerPage ( 5 );
$paginator -> setView ( $this -> view );
Zend_View_Helper_PaginationControl :: setDefaultViewPartial ( 'data/pagination_ajax.phtml' );
2013-01-16 08:09:14 +00:00
include_once ( " Avatar.php " );
$avatar = new Avatar ();
2011-10-28 03:18:44 +00:00
if ( $paginator )
2011-09-20 02:58:44 +00:00
{
2011-10-28 03:18:44 +00:00
foreach ( $paginator as $c )
2011-09-20 02:58:44 +00:00
{
//$author=$this->view->escape($c['author']);
2013-01-16 08:09:14 +00:00
$sql = " SELECT cr.id,cr.content as body,cr.reply,u.username,cr.ts_created,u.usertype,u.email as email,
2012-12-06 07:17:04 +00:00
( SELECT au . uuid FROM mdauthor au WHERE au . userid = u . id AND au . uuid = '$uuid' ) as uuid
FROM comments cr
LEFT JOIN users u ON cr . userid = u . id
WHERE cr . reply = ? " ;
2012-09-17 02:08:22 +00:00
$sth = $this -> db -> prepare ( $sql );
$sth -> execute ( array ( $c [ 'id' ]));
$replys = $sth -> fetchAll ();
$replyhtml = " " ;
if ( ! empty ( $replys ) || count ( $replys ) > 0 )
{
foreach ( $replys as $v )
{
2012-12-06 07:17:04 +00:00
$usertype = " " ;
$color = " " ;
if ( $v [ 'usertype' ] == " administrator " )
{
$usertype = " [管理员] " ;
$color = " #009d00 " ;
}
if ( $v [ 'uuid' ] == $uuid )
{
$usertype = " [数据作者] " ;
$color = " #add2e9 " ;
}
if ( ! empty ( $color ))
{
$color = 'background:' . $color . ';color:#FFFFFF;' ;
}
2013-03-22 03:47:41 +00:00
$img = $avatar -> Get ( $v [ 'email' ], 48 );
$replyhtml .= '
< div class = " media " style = " background:#cecece;border-radius:6px 6px 6px 6px; " >
< a class = " pull-left " href = " javascript:void(0); " >
< img class = " media-object img-rounded " src = " '. $img .' " >
</ a >
< div class = " media-body " >
< span class = " pull-right " > 回复于 '.date(' Y - m - d H : i : s ',strtotime($v[' ts_created '])).' </ span >
< h5 class = " media-heading " > '.$v[' username '].' '.$usertype.' </ h5 >
'.$v[' body '].'
</ div >
</ div >
' ;
2012-09-17 02:08:22 +00:00
}
}
2013-01-16 08:09:14 +00:00
2013-03-22 03:47:41 +00:00
$img = $avatar -> Get ( $c [ 'email' ], 64 );
2013-03-19 09:16:41 +00:00
//$img = '<img src="'.$img.'" />';
2013-01-16 08:09:14 +00:00
$author = $c [ 'author' ];
$author = ( $c [ 'url' ]) ? '<a href="' . $c [ 'url' ] . '">' . $author . '</a>' : $author ;
2013-03-19 09:16:41 +00:00
$author = '' . $author . " " ;
$time = '发表于' . date ( 'Y-m-d H:i:s' , strtotime ( $c [ 'ts_created' ])) . '' ;
print '
2013-03-22 03:47:41 +00:00
< div class = " media " style = " background:#eee;border-radius:6px 6px 6px 6px; " >
< img class = " media-object img-rounded pull-left " src = " '. $img .' " >
2013-03-19 09:16:41 +00:00
< div class = " media-body " >
< span class = " pull-right " > '.$time.' </ span >
< h4 class = " media-heading " > '.$c[' author '].' </ h4 >
'.$c[' content '].'
'.$replyhtml.'
</ div >
</ div >
' ;
2011-09-20 02:58:44 +00:00
}
2011-10-28 03:18:44 +00:00
echo '<div class="paginator">' . $paginator . '</div>' ;
2011-09-20 02:58:44 +00:00
} //else echo "<li>No comments.</li>";
2011-11-24 03:27:25 +00:00
} //评论列表
2011-09-20 02:58:44 +00:00
/**
* 判断用户是否填写了申请信息
* @ param string $uuid
* @ param int $userid
*/
function todownloadAction () {
2013-03-15 04:16:07 +00:00
$this -> view -> pageID = " account-dataorder " ;
2011-09-20 02:58:44 +00:00
2013-03-15 04:16:07 +00:00
$this -> _helper -> viewRenderer ( 'onlineapp-download' );
$this -> view -> uuid = $uuid = $this -> _request -> getParam ( 'uuid' );
$auth = Zend_Auth :: getInstance ();
2011-09-20 02:58:44 +00:00
if ( ! $auth -> hasIdentity ())
{
2013-03-15 04:16:07 +00:00
$this -> view -> AlertType = " alert-error " ;
$this -> view -> msg = " 请先登录您的账户后进行下载,页面将自动跳转 " ;
$this -> view -> jump_url = '/account/login/?href=/data/todownload/uuid/' . $uuid ;
return true ;
}
if ( empty ( $uuid ))
{
$this -> view -> AlertType = " alert-error " ;
$this -> view -> msg = " 参数错误! " ;
$this -> view -> jump_url = " /data " ;
return true ;
}
$this -> view -> projectType = array (
" 无 " => '' ,
" 国家973计划项目课题 " => " 国家973计划项目课题 " ,
" 国家863计划课题 " => " 国家863计划课题 " ,
" 国家级科技支撑课题 " => " 国家级科技支撑课题 " ,
" 国家级科技重大专项 " => " 国家级科技重大专项 " ,
" 国家级国家重大工程 " => " 国家级国家重大工程 " ,
" 国家级国家自然科学基金 " => " 国家级国家自然科学基金 " ,
" 国际合作项目 " => " 国际合作项目 " ,
" 省部级项目 " => " 省部级项目 " ,
" 其他项目工程 " => " 其他项目工程 "
);
$userid = Zend_Auth :: getInstance () -> getIdentity () -> id ;
$submit = $this -> _getParam ( 'submit' );
if ( ! empty ( $submit )){
$datas = array ();
$datas [ 'realname' ] = $this -> _request -> getParam ( 'realname' );
$datas [ 'unit' ] = $this -> _request -> getParam ( 'unit' );
$datas [ 'phone' ] = $this -> _request -> getParam ( 'phone' );
$datas [ 'address' ] = $this -> _request -> getParam ( 'address' );
$datas [ 'postcode' ] = $this -> _request -> getParam ( 'postcode' );
$datas [ 'email' ] = $this -> _request -> getParam ( 'email' );
$datas [ 'project' ] = $this -> _request -> getParam ( 'project' );
$datas [ 'project_id' ] = $this -> _request -> getParam ( 'project_id' );
$datas [ 'project_type' ] = $this -> _request -> getParam ( 'project_type' );
$datas [ 'project_title' ] = $this -> _request -> getParam ( 'project_title' );
$this -> view -> info = $datas ;
$this -> view -> AlertType = " alert-error " ;
foreach ( $datas as $k => $v )
{
if ( empty ( $v ))
{
$this -> view -> error = " 每一项内容都需要填写 " ;
return true ;
}
}
if ( ! is_numeric ( $datas [ 'postcode' ]))
{
$this -> view -> error = " 联系电话和邮政编码请填写数字 " ;
return true ;
}
if ( ! preg_match ( " / \ w+([-+.] \ w+)*@ \ w+([-.] \ w+)* \ . \ w+([-.] \ w+)*/i " , $datas [ 'email' ]))
{
$this -> view -> error = " 请填写正确的email地址 " ;
return true ;
}
if ( mb_strlen ( $datas [ 'project' ], " utf-8 " ) < 8 )
{
$this -> view -> error = " 项目介绍内容不少于8个字符 " ;
return true ;
}
if ( preg_match ( '/^\d+$/' , $datas [ 'project' ]))
{
$this -> view -> error = " 请输入有意义的项目介绍内容 " ;
return true ;
}
$data = array (
'userid' => $userid ,
'username' => $datas [ 'realname' ],
'unit' => $datas [ 'unit' ],
'phone' => $datas [ 'phone' ],
'address' => $datas [ 'address' ],
'postcode' => $datas [ 'postcode' ],
'project' => $datas [ 'project' ],
'uuid' => $uuid ,
'email' => $datas [ 'email' ],
'project_id' => $datas [ 'project_id' ],
'project_title' => $datas [ 'project_title' ],
'project_type' => $datas [ 'project_type' ]
);
if ( $this -> db -> insert ( 'onlineapp' , $data ))
{
$select = " select id from onlineapp where userid=' $userid ' order by id desc " ;
$re = $this -> db -> query ( $select );
$row = $re -> fetch ();
$this -> view -> AlertType = " alert-success " ;
$this -> view -> jump_url = '/data/download/uuid/' . $uuid . '/onlineappid/' . $row [ 'id' ];
$this -> view -> msg = " 您的信息已经提交成功,可以进行下载。请等待页面自动跳转,<a href= \" " . $this -> view -> jump_url . " \" >或点击这里进入下载页面</a> " ;
$msg = " 用户 { $data [ 'username' ] } 填写了在线数据申请表 <a href= \" /admin/down/online/show/ { $row [ 'id' ] } \" >查看详细</a> " ;
$title = " 用户 { $data [ 'username' ] } 申请了在线下载数据 " ;
include_once ( " message.php " );
message :: post ( $this -> db , 0 , - 1 , $title , $msg );
return true ;
}
else {
$this -> view -> AlertType = " alert-error " ;
$this -> view -> error = " 申请失败,请稍后重新尝试 " ;
$this -> view -> info = $data ;
return true ;
}
return true ;
} else {
$testsql = " select * from onlineapp where userid=' $userid ' and uuid=' $uuid ' order by id desc " ;
$result = $this -> db -> query ( $testsql );
$rows = $result -> fetch ();
if ( empty ( $rows [ 'id' ]))
{
include_once ( " Users.php " );
$usr = new Users ( $this -> db );
$this -> view -> info = $usr -> getUserInfo ( $userid );
return true ;
}
else
{
$datas [ 'realname' ] = $rows [ 'username' ];
$datas [ 'unit' ] = $rows [ 'unit' ];
$datas [ 'phone' ] = $rows [ 'phone' ];
$datas [ 'address' ] = $rows [ 'address' ];
$datas [ 'postcode' ] = $rows [ 'postcode' ];
$datas [ 'email' ] = $rows [ 'email' ];
$datas [ 'project' ] = $rows [ 'project' ];
$datas [ 'project_id' ] = $rows [ 'project_id' ];
$datas [ 'project_type' ] = $rows [ 'project_type' ];
$datas [ 'project_title' ] = $rows [ 'project_title' ];
$this -> view -> info = $datas ;
return true ;
}
}
return true ;
2011-09-20 02:58:44 +00:00
$userid = Zend_Auth :: getInstance () -> getIdentity () -> id ;
$datas = array ();
$submited = $this -> _request -> getParam ( 'submited' );
$datas [ 'username' ] = $this -> _request -> getParam ( 'username' );
$datas [ 'unit' ] = $this -> _request -> getParam ( 'unit' );
$datas [ 'phone' ] = $this -> _request -> getParam ( 'phone' );
$datas [ 'address' ] = $this -> _request -> getParam ( 'address' );
$datas [ 'postcode' ] = $this -> _request -> getParam ( 'postcode' );
$datas [ 'email' ] = $this -> _request -> getParam ( 'email' );
$datas [ 'project' ] = $this -> _request -> getParam ( 'project' );
2012-06-06 08:19:56 +00:00
$datas [ 'project_id' ] = $this -> _request -> getParam ( 'projectid' );
$datas [ 'project_type' ] = $this -> _request -> getParam ( 'projecttype' );
$datas [ 'project_title' ] = $this -> _request -> getParam ( 'projecttitle' );
2011-09-20 02:58:44 +00:00
$form = $this -> creatform ( $datas );
if ( ! empty ( $submited ) && $ft == 0 ){
foreach ( $datas as $k => $v )
{
2012-09-06 02:32:45 +00:00
if ( $v == '' )
2011-09-20 02:58:44 +00:00
{
echo $form . '<script>alert("每一项内容都需要填写")</script>' ;
exit ();
}
}
if ( ! is_numeric ( $datas [ 'postcode' ]))
{
echo $form . '<script>alert("联系电话和邮政编码请填写数字")</script>' ;
exit ();
}
if ( ! preg_match ( " / \ w+([-+.] \ w+)*@ \ w+([-.] \ w+)* \ . \ w+([-.] \ w+)*/i " , $datas [ 'email' ]))
{
echo $form . '<script>alert("请填写正确的email地址")</script>' ;
exit ();
}
2012-10-16 03:29:43 +00:00
if ( mb_strlen ( $datas [ 'project' ], " utf-8 " ) < 8 )
{
echo $form . '<script>alert("项目介绍内容不少于8个字符")</script>' ;
exit ();
}
if ( preg_match ( '/^\d+$/' , $datas [ 'project' ]))
{
echo $form . '<script>alert("请输入有意义的项目介绍内容")</script>' ;
exit ();
}
2011-09-20 02:58:44 +00:00
$data = array (
'userid' => $userid ,
'username' => $datas [ 'username' ],
'unit' => $datas [ 'unit' ],
'phone' => $datas [ 'phone' ],
'address' => $datas [ 'address' ],
'postcode' => $datas [ 'postcode' ],
'project' => $datas [ 'project' ],
'uuid' => $uuid ,
2012-06-06 08:19:56 +00:00
'email' => $datas [ 'email' ],
'project_id' => $datas [ 'project_id' ],
'project_title' => $datas [ 'project_title' ],
'project_type' => $datas [ 'project_type' ]
2011-09-20 02:58:44 +00:00
);
if ( $this -> db -> insert ( 'onlineapp' , $data ))
{
$select = " select id from onlineapp where userid=' $userid ' order by id desc " ;
$re = $this -> db -> query ( $select );
$row = $re -> fetch ();
echo " 您的信息已经提交成功,可以进行下载。<br />
如果页面没有自动跳转, < a href = '/data/download/uuid/$uuid/onlineappid/{$row[' id ']}' > 请点击这里进入下载页面 </ a >
< script > self . location = '/data/download/uuid/$uuid/onlineappid/{$row[' id ']}' </ script > " ;
2011-11-17 07:58:56 +00:00
$msg = " 用户 { $data [ 'username' ] } 填写了在线数据申请表 <a href= \" /admin/down/online/show/ { $row [ 'id' ] } \" >查看详细</a> " ;
$title = " 用户 { $data [ 'username' ] } 申请了在线下载数据 " ;
include_once ( " message.php " );
message :: post ( $this -> db , 0 , - 1 , $title , $msg );
2011-09-20 02:58:44 +00:00
exit ();
}
else {
echo $form . '<script>alert("服务器忙,请重试")</script>' ;
exit ();
}
} else if ( $ft == 1 )
{
$testsql = " select * from onlineapp where userid=' $userid ' and uuid=' $uuid ' order by id desc " ;
$result = $this -> db -> query ( $testsql );
$rows = $result -> fetch ();
if ( empty ( $rows [ 'id' ]))
{
$sql = " select * from users where id=' $userid ' " ;
$result = $this -> db -> query ( $sql );
$rows = $result -> fetch ();
$datas [ 'username' ] = $rows [ 'realname' ];
$datas [ 'unit' ] = $rows [ 'unit' ];
$datas [ 'phone' ] = $rows [ 'phone' ];
$datas [ 'address' ] = $rows [ 'address' ];
2012-06-07 10:17:10 +00:00
$datas [ 'postcode' ] = $rows [ 'postcode' ];
2011-09-20 02:58:44 +00:00
$datas [ 'email' ] = $rows [ 'email' ];
2012-06-11 03:26:41 +00:00
$datas [ 'project' ] = $rows [ 'project' ];
2012-06-07 10:17:10 +00:00
$datas [ 'project_id' ] = $rows [ 'project_id' ];
2012-06-11 03:26:41 +00:00
$datas [ 'project_type' ] = $rows [ 'project_type' ];
$datas [ 'project_title' ] = $rows [ 'project_title' ];
2011-09-20 02:58:44 +00:00
echo $this -> creatform ( $datas );
exit ();
}
else
{
$datas [ 'username' ] = $rows [ 'username' ];
$datas [ 'unit' ] = $rows [ 'unit' ];
$datas [ 'phone' ] = $rows [ 'phone' ];
$datas [ 'address' ] = $rows [ 'address' ];
$datas [ 'postcode' ] = $rows [ 'postcode' ];
$datas [ 'email' ] = $rows [ 'email' ];
$datas [ 'project' ] = $rows [ 'project' ];
2012-06-07 10:17:10 +00:00
$datas [ 'project_id' ] = $rows [ 'project_id' ];
2012-06-11 03:26:41 +00:00
$datas [ 'project_type' ] = $rows [ 'project_type' ];
$datas [ 'project_title' ] = $rows [ 'project_title' ];
2011-09-20 02:58:44 +00:00
echo $this -> creatform ( $datas );
exit ();
}
}
}
/*
* 数据下载, 根据UUID进行判断
* 一次只下载一个数据(一个元数据项)
*/
function downloadAction ()
{
$uuid = $this -> _request -> getParam ( 'uuid' );
2013-05-26 12:08:28 +00:00
$onlineappid = $this -> _request -> getParam ( 'onlineappid' );
$this -> view -> pageID = " account-dataorder " ;
2011-09-20 02:58:44 +00:00
if ( empty ( $uuid )) $this -> _redirect ( '/data' );
2012-12-06 03:16:43 +00:00
$auth = Zend_Auth :: getInstance ();
if ( $auth -> hasIdentity ())
{
$user = $auth -> getIdentity ();
$userid = $user -> id ;
}
2012-12-06 05:48:55 +00:00
$testsql = " select id,has_send_mail from onlineapp where userid=' $userid ' and uuid=' $uuid ' order by id desc " ;
2011-09-20 02:58:44 +00:00
$result = $this -> db -> query ( $testsql );
2012-12-06 07:17:04 +00:00
$rows = $result -> fetch ();
2013-05-26 03:58:38 +00:00
$has_send_mail = $rows [ 'has_send_mail' ];
2011-09-20 02:58:44 +00:00
if ( empty ( $rows [ 'id' ]))
{
$this -> _redirect ( '/data/' . $uuid );
}
else
{
2012-01-07 11:06:27 +00:00
$sql = " select onlineappid,id from dataorder where status=0 and userid=' $userid ' and uuid=' $uuid ' order by id desc " ;
2011-09-20 02:58:44 +00:00
$re = $this -> db -> query ( $sql );
$row = $re -> fetch ();
if ( empty ( $row [ 'onlineappid' ]))
{
$data = array (
'userid' => $userid ,
'uuid' => $uuid ,
2012-01-12 07:53:58 +00:00
'onlineappid' => $onlineappid ,
2012-01-07 11:06:27 +00:00
'ts_approved' => 'now()' ,
2011-09-20 02:58:44 +00:00
);
try { $this -> db -> insert ( 'dataorder' , $data );} catch ( Exception $e ) {}
} else
{
2012-01-07 11:06:27 +00:00
$sql = " update dataorder set onlineappid=' $onlineappid ',ts_approved=now() where id=' { $row [ 'id' ] } ' " ;
2011-09-20 02:58:44 +00:00
try { $this -> db -> exec ( $sql );} catch ( Exception $e ) {}
}
2012-12-06 07:17:04 +00:00
}
2012-12-06 05:48:55 +00:00
2013-05-26 03:58:38 +00:00
$sql = $this -> db -> quoteInto ( " select * from dataset o left join metadata m on o.uuid=m.uuid left join mdstatus s on m.uuid=s.uuid where s.status>4 and m.datatype=0 and m.uuid=? " , $uuid );
$data = $this -> db -> fetchRow ( $sql );
2011-09-20 02:58:44 +00:00
$updateftp = $updateftp1 = false ;
2013-05-26 03:58:38 +00:00
$this -> view -> md = $data ;
2011-09-20 02:58:44 +00:00
$this -> view -> userpass = md5 ( 'westdc' . rand ( 1000 , 9999 ));
2013-05-26 12:08:28 +00:00
$this -> view -> ftptime = date ( 'Y-m-d H:i:s' , strtotime ( '+1 week' ));
$sql = $this -> db -> quoteInto ( " select * from ftpuser where userid=? " , $userid );
$row = $this -> db -> fetchRow ( $sql );
2011-09-20 02:58:44 +00:00
$datacount = $row [ 'datacount' ];
2013-05-26 03:58:38 +00:00
if ( $data [ 'host' ] == 'ftp.westgis.ac.cn' )
{
//添加FTP帐号信息以及时间控制信息
$updateftp = true ;
$g6 = new G6ftp ();
$g6 -> db = $this -> db ;
//不进行判断,每个元数据中的下载地址都对应一个虚拟路径
$path [] = $data [ 'path' ];
$this -> view -> username = 'westdc' . $userid ;
$uu = ( object ) array ( " id " => $userid ,
" username " => $this -> view -> username ,
" password " => $this -> view -> userpass ,
" path " => $path ,
" maxdata " => $this -> view -> config -> download -> max ,
" time " => $this -> view -> ftptime ,
" datacount " => $datacount );
if ( $g6 -> createuser ( $uu )) {
$this -> view -> userpass = $g6 -> pwd ;
$this -> view -> ftptime = $g6 -> time ;
} else {
$this -> messenger -> addMessage ( '错误:您正在进行下载的在线数据数已经超过系统允许的最大值,请在下面点击“完成”或“取消”对应的在线数据下载!' );
$this -> _redirect ( '/data/order' );
2011-09-20 02:58:44 +00:00
}
2013-05-26 03:58:38 +00:00
} elseif ( $data [ 'host' ] == 'ftp1.westgis.ac.cn' )
{
//添加FTP1帐号信息以及时间控制信息
$proftp = new Proftp ();
$proftp -> db = $this -> db ;
//proftp离线用户名和g6的用户名稍有不同
$this -> view -> username = 'westdc_' . $userid ;
$uu = ( object ) array ( " id " => $userid ,
" username " => $this -> view -> username ,
" password " => $this -> view -> userpass ,
" host " => 'ftp1.westgis.ac.cn' ,
" param " => " onlineappid= " . $onlineappid ,
" maxdata " => $this -> view -> config -> download -> max ,
" time " => $this -> view -> ftptime ,
" datacount " => $datacount );
if ( $proftp -> createuser ( $uu ))
{
$this -> view -> userpass = $proftp -> pwd ;
$this -> view -> ftptime = $proftp -> time ;
}
} elseif ( $data [ 'host' ] == 'ftp2.westgis.ac.cn' )
{
//添加FTP2帐号信息以及时间控制信息
$proftp = new Pureftp ();
$proftp -> db = $this -> db ;
$this -> view -> username = 'westdc_' . $userid ;
$uu = ( object ) array ( " id " => $userid ,
" username " => $this -> view -> username ,
" password " => $this -> view -> userpass ,
" host " => 'ftp2.westgis.ac.cn' ,
" param " => " onlineappid= " . $onlineappid ,
" maxdata " => $this -> view -> config -> download -> max ,
" time " => $this -> view -> ftptime ,
" datacount " => $datacount );
if ( $proftp -> createuser ( $uu ))
{
$this -> view -> userpass = $proftp -> pwd ;
$this -> view -> ftptime = $proftp -> time ;
}
}
$ftpurl = 'ftp://' . $this -> view -> username . '@' . $data [ 'host' ] . $data [ 'path' ];
2011-09-20 02:58:44 +00:00
//设置输出
//if ($updateftp || $updateftp1) $this->view->userpass=$password;
2013-05-26 12:08:28 +00:00
$this -> view -> ftpurl = $ftpurl ;
2013-05-26 03:58:38 +00:00
//更新下载记录
2011-09-20 02:58:44 +00:00
//todo: 尝试添加一个RULE: 若有对应数据存在, 则不插入( userid,uuid,status=0,ts_approved:null)
2012-01-07 11:06:27 +00:00
/* $sql = " select * from dataorder where userid=? and uuid=? and status=0 and (ts_approved is null) " ;
2011-09-20 02:58:44 +00:00
$u = $this -> db -> fetchRow ( $sql , array ( $userid , $uuid ));
if ( empty ( $u )) {
$sql = " insert into dataorder (userid,uuid,ts_created) values(?,?,now()) " ;
$this -> db -> query ( $sql , array ( $userid , $uuid ));
2012-12-06 07:17:04 +00:00
} */
2013-05-26 03:58:38 +00:00
if ( ! empty ( $ftpurl ) && ! $has_send_mail )
{
$data = array (
" uuid " => $uuid ,
" title " => $this -> view -> md [ 'title' ] . " ( " . $this -> view -> md [ 'filesize' ] . " MB) " ,
" user " => $user -> username ,
" ftpuser " => $this -> view -> username ,
" ftppwd " => $this -> view -> userpass ,
" ftptime " => $this -> view -> ftptime ,
" ftpurl " => $this -> view -> ftpurl ,
" note " => $updateftp ? 'BTW: 请注意登陆后要手工进入对应的目录! ' : ''
);
$mailtp = new EmailText ( $this -> db , 'online-download' , $data );
$mail = new WestdcMailer ( $this -> view -> config -> smtp );
$mail -> setBodyText ( $mailtp -> getBody ());
$mail -> setFrom ( $this -> view -> config -> service -> email , '西部数据中心服务组' );
$mail -> addTo ( $user -> email );
$mail -> setSubject ( $mailtp -> getSubject ());
@ $mail -> send ();
$sql = " update onlineapp set has_send_mail=true where id=? " ;
$sth = $this -> db -> prepare ( $sql );
$sth -> execute ( array ( $onlineappid ));
}
2012-12-06 03:16:43 +00:00
}
2011-09-20 02:58:44 +00:00
/*
* 离线申请(可以包括在线数据),在无数据参数时,则显示已有列表
*/
function orderAction ()
{
2013-04-03 02:51:15 +00:00
$this -> view -> pageID = " account-dataorder " ;
2011-09-20 02:58:44 +00:00
$uuid = $this -> _request -> getParam ( 'uuid' );
$del = $this -> _request -> getParam ( 'del' );
$apply = $this -> _request -> getParam ( 'apply' );
$finish = $this -> _request -> getParam ( 'finish' );
$cancel = $this -> _request -> getParam ( 'cancel' );
$pdf = $this -> _request -> getParam ( 'pdf' );
//if (empty($uuid)) $this->_redirect('/data');
$userid = Zend_Auth :: getInstance () -> getIdentity () -> id ;
if ( $uuid )
{
//处理数据入库
//离线申请的数据不应该重复, 因此需要在数据库限制? 还是在WEB端限制?
//在数据库中控制, 只保证uuid,userid,status唯一就可以?
//存在历史遗留问题,原来的数据并不能保证唯一
//status: 1 开始进入离线申请申请程序中
// 2 填写并提交离线申请表
// 3 邮寄离线申请表
// 4 收到离线申请表
// 5 处理离线申请表
// 10:离线申请完成?
// -1: 取消了在线下载进程
//首先判断离线申请的数据数量是否超过系统限制
2012-01-12 07:53:58 +00:00
$sql = " select count(*) as datacount from dataorder where (ts_approved is null) and userid=? and status>0 and status<3 " ;
2011-12-07 06:06:48 +00:00
$r = $this -> db -> fetchRow ( $this -> db -> quoteInto ( $sql , $userid ));
2011-09-20 02:58:44 +00:00
//保证添加的离线数据申请未申请
2011-12-07 06:06:48 +00:00
$sql = " select count(*) as datacount from dataorder where (ts_approved is null) and userid=' $userid ' and uuid=? and status in (1,2,3,4) " ;
2011-12-29 08:09:58 +00:00
$r1 = $this -> db -> fetchRow ( $this -> db -> quoteInto ( $sql , $uuid ));
//保证添加的离线数据是正式发布的数据
$sql = " select count(*) as mdcount from normalmetadata where uuid=? " ;
2011-12-07 06:06:48 +00:00
$r2 = $this -> db -> fetchRow ( $this -> db -> quoteInto ( $sql , $uuid ));
if ( $r [ 'datacount' ] < $this -> view -> config -> download -> max && $r1 [ 'datacount' ] < 1 && $r2 [ 'mdcount' ] > 0 ) {
2011-09-20 02:58:44 +00:00
$sql = " insert into dataorder (uuid,ts_created,userid,status) values(?,now(),?,?) " ;
$this -> db -> query ( $sql , array ( $uuid , $userid , 1 ));
//成功信息提示
$sql = $this -> db -> quoteInto ( " select title,uuid from metadata where uuid=? " , $uuid );
$this -> view -> md = $this -> db -> fetchRow ( $sql );
} else {
if ( $r1 [ 'datacount' ] >= 1 )
2011-12-29 08:09:58 +00:00
$this -> view -> msg = " 错误:您申请的数据已经在数据蓝中! " ;
elseif ( $r2 [ 'mdcount' ] == 0 )
2011-12-07 06:06:48 +00:00
$this -> view -> msg = " 错误:您申请的数据不存在。 " ;
2011-09-20 02:58:44 +00:00
else
$this -> view -> msg = " 错误:您正在进行的离线申请的数据数已经超过系统允许的最大值,请在完成本次离线申请后再进行操作! " ;
}
} elseif ( $del ) {
//删除数据申请
2012-05-16 02:00:29 +00:00
$sql = $this -> db -> quoteInto ( " delete from dataorder where userid= " . $userid . " and status in (1,2) and id=? " , $del );
2011-09-20 02:58:44 +00:00
$this -> db -> query ( $sql );
$this -> _redirect ( '/data/order' );
} elseif ( $apply ) {
if ( $apply == 'all' ) {
$sql = $this -> db -> quoteInto ( " update dataorder set status=2 where status=1 and userid=? " , $userid );
$this -> db -> query ( $sql );
} else {
$sql = " update dataorder set status=2 where status=1 and userid=? and id=? " ;
$this -> db -> query ( $sql , array ( $userid ,( int ) $apply ));
}
} elseif ( $finish ) {
if ( $finish == 'all' ) {
$sql = $this -> db -> quoteInto ( " update dataorder set ts_approved=now() where status=0 and userid=? " , $userid );
$this -> db -> query ( $sql );
$sql = " update ftpuser set datacount=0 where userid=? " ;
$this -> db -> query ( $sql , array ( $userid ));
} else {
$sql = " update dataorder set ts_approved=now() where status=0 and userid=? and id=? " ;
$this -> db -> query ( $sql , array ( $userid ,( int ) $finish ));
2012-05-16 02:00:29 +00:00
$sql = " update ftpuser set datacount=datacount-1 where userid=? and datacount>0 " ;
2011-09-20 02:58:44 +00:00
$this -> db -> query ( $sql , array ( $userid ));
}
} elseif ( $cancel ) {
if ( $cancel == 'all' ) {
$sql = $this -> db -> quoteInto ( " update dataorder set ts_approved=now(),status=-1 where status=0 and userid=? " , $userid );
$this -> db -> query ( $sql );
$sql = " update ftpuser set datacount=0 where userid=? " ;
$this -> db -> query ( $sql , array ( $userid ));
} else {
2012-05-16 02:00:29 +00:00
$sql = " update dataorder set ts_approved=now(),status=-1 where status in (0,1,2) and userid=? and id=? " ;
2011-09-20 02:58:44 +00:00
$this -> db -> query ( $sql , array ( $userid ,( int ) $cancel ));
2012-05-16 02:00:29 +00:00
$sql = " update ftpuser set datacount=datacount-1 where userid=? and datacount>0 " ;
2011-09-20 02:58:44 +00:00
$this -> db -> query ( $sql , array ( $userid ));
}
} elseif ( $pdf ) {
//生成PDF离线申请文件
//用户信息可以从SESSION中读取? 离线申请信息
//$sql="select * from users where id=?";
2011-11-22 14:22:09 +00:00
$sql = " select m.title||'('||m.filesize::text||'MB)' as title,m.citation,m.suppinfo from dataorder d left join metadata m on d.uuid=m.uuid where d.status=2 and d.userid=? order by d.ts_created desc " ;
2011-09-20 02:58:44 +00:00
$rows = $this -> db -> fetchAll ( $sql , array ( $userid ));
if ( $rows ) {
$this -> view -> data2 = $rows ;
$this -> view -> form = new OfflinePdfForm ();
$this -> _helper -> viewRenderer ( 'pdf' );
if ( $this -> _request -> isPost ()) {
$formData = $this -> _request -> getPost ();
$datalist = '' ;
foreach ( $rows as $i => $row ) $datalist .= ( $i + 1 ) . " . " . $row [ 'title' ] . " ; " ;
$formData [ 'datalist' ] = $datalist ;
if ( $this -> view -> form -> isValid ( $formData )) {
if ( @ $formData [ 'save' ]) {
//保存
//根据pdflink字段, 以判断是否已经提交
//在数据库中创建rules, 在更新offlineapp表时同时更新users表中对应的信息
$sql = " select id from offlineapp where userid=? and (pdflink is null or pdflink='') and (ts_approved is null) " ;
$row = $this -> db -> fetchRow ( $sql , array ( $userid ));
if ( $row ) {
2012-06-11 03:26:41 +00:00
$sql = " update offlineapp set username=?,email=?,phone=?,address=?,postcode=?,project=?,unit=?,datalist=?,ts_created=now(),project_type=?,project_id=?,project_title=? where id=? " ;
2012-06-11 11:48:54 +00:00
$this -> db -> query ( $sql , array ( $formData [ 'realname' ], $formData [ 'email' ], $formData [ 'phone' ], $formData [ 'address' ], $formData [ 'postcode' ], $formData [ 'project' ], $formData [ 'unit' ], $datalist , $formData [ 'project_type' ], $formData [ 'project_id' ], $formData [ 'project_title' ], $row [ 'id' ]));
2011-09-20 02:58:44 +00:00
} else {
2012-06-11 03:26:41 +00:00
$sql = " insert into offlineapp (userid,username,email,phone,address,postcode,project,unit,datalist,project_type,project_id,project_title) values(?,?,?,?,?,?,?,?,?,?,?,?) " ;
2012-06-11 11:48:54 +00:00
$this -> db -> query ( $sql , array ( $userid , $formData [ 'realname' ], $formData [ 'email' ], $formData [ 'phone' ], $formData [ 'address' ], $formData [ 'postcode' ], $formData [ 'project' ], $formData [ 'unit' ], $datalist , $formData [ 'project_type' ], $formData [ 'project_id' ], $formData [ 'project_title' ]));
2011-09-20 02:58:44 +00:00
}
$this -> _helper -> layout -> disableLayout ();
$this -> _helper -> viewRenderer -> setNoRender ();
//生成PDF
$pdf = new ApplicantPDF ();
2012-06-13 04:05:33 +00:00
$pdf -> template = $this -> view -> config -> offline -> template ;
2012-06-11 11:48:54 +00:00
$formData [ 'project' ] .= '[' . $formData [ 'project_title' ] . ' | ' . $formData [ 'project_type' ] . ' | ' . $formData [ 'project_id' ] . ']' ;
2011-09-20 02:58:44 +00:00
$pdf -> data = $formData ;
2011-11-23 08:12:29 +00:00
$pdf -> drawWestdc ();
$pdf -> addRef ( $rows );
2011-11-22 14:22:09 +00:00
$pdf -> addSecurity ( $this -> view -> config -> offline -> security );
2011-09-20 02:58:44 +00:00
header ( " Content-Disposition: inline; filename=westdc-data-apply.pdf " );
header ( " Content-Type:application/pdf " );
//header("Content-Length: " . strlen($pdfstring));
echo $pdf -> Output ( 'westdc-data-apply.pdf' , 'S' );
die ();
//exit;
} elseif ( $formData [ 'submit' ]) {
//提交
//生成PDF
$pdf = new ApplicantPDF ();
2012-06-13 04:05:33 +00:00
$pdf -> template = $this -> view -> config -> offline -> template ;
$pdf -> data = $formData ;
2012-06-11 11:48:54 +00:00
$pdf -> data [ 'project' ] .= '[' . $formData [ 'project_title' ] . ' | ' . $formData [ 'project_type' ] . ' | ' . $formData [ 'project_id' ] . ']' ;
2011-09-20 02:58:44 +00:00
$pdf -> drawWestdc ();
2011-11-23 08:12:29 +00:00
$pdf -> addRef ( $rows );
2011-11-22 14:22:09 +00:00
$pdf -> addSecurity ( $this -> view -> config -> offline -> security );
2011-09-20 02:58:44 +00:00
$fn = $formData [ 'realname' ] . date ( 'YmdHis' ) . " .pdf " ;
$pdf -> Output ( $this -> view -> config -> offline -> savepath . " / " . $fn , 'F' );
//保存到数据库
$sql = " select id from offlineapp where userid=? and pdflink is null and (ts_approved is null) " ;
$row = $this -> db -> fetchRow ( $sql , array ( $userid ));
if ( $row ) {
2012-06-11 03:26:41 +00:00
$sql = " update offlineapp set username=?,email=?,phone=?,address=?,postcode=?,project=?,unit=?,datalist=?,ts_created=now(),pdflink=?,project_type=?,project_id=?,project_title=? where id=? " ;
2012-06-11 11:48:54 +00:00
$this -> db -> query ( $sql , array ( $formData [ 'realname' ], $formData [ 'email' ], $formData [ 'phone' ], $formData [ 'address' ], $formData [ 'postcode' ], $formData [ 'project' ], $formData [ 'unit' ], $datalist , $fn , $formData [ 'project_type' ], $formData [ 'project_id' ], $formData [ 'project_title' ], $row [ 'id' ]));
2011-09-20 02:58:44 +00:00
} else {
2012-06-11 03:26:41 +00:00
$sql = " insert into offlineapp (userid,username,email,phone,address,postcode,project,unit,datalist,pdflink,project_type,project_id,project_title) values(?,?,?,?,?,?,?,?,?,?,?,?,?) " ;
2012-06-11 11:48:54 +00:00
$this -> db -> query ( $sql , array ( $userid , $formData [ 'realname' ], $formData [ 'email' ], $formData [ 'phone' ], $formData [ 'address' ], $formData [ 'postcode' ], $formData [ 'project' ], $formData [ 'unit' ], $datalist , $fn , $formData [ 'project_type' ], $formData [ 'project_id' ], $formData [ 'project_title' ]));
2011-09-20 02:58:44 +00:00
$sql = " select id from offlineapp where userid=? and pdflink=? " ;
$row = $this -> db -> fetchRow ( $sql , array ( $userid , $fn ));
}
$sql = " update dataorder set status=3, offlineappid=? where status=2 and userid=? " ;
$this -> db -> query ( $sql , array ( $row [ 'id' ], $userid ));
//发送用户邮件进行信息提示和说明
//$mail = new Zend_Mail('utf-8');
$mail = new WestdcMailer ( $this -> view -> config -> smtp );
$body = file_get_contents ( $this -> view -> config -> offline -> email -> template );
$body = str_replace ( " [username] " , $formData [ 'realname' ], $body );
$body = str_replace ( " [datalist] " , str_replace ( " ; " , " \n " , $datalist ), $body );
$mail -> setBodyText ( $body );
$mail -> addTo ( $formData [ 'email' ]);
$mail -> setSubject ( '您在西部数据中心进行的离线申请' );
$mail -> setFrom ( $this -> view -> config -> service -> email , '西部数据中心服务组' );
$attach = $mail -> createAttachment ( $pdf -> Output ( 'applicant' , 'S' ));
$attach -> filename = '数据申请-' . $formData [ 'realname' ] . '.pdf' ;
$mail -> send ();
//跳转到/data/order, 并提示帮助信息, 告知用户已经发送EMAIL
$this -> messenger -> addMessage ( '提示信息:您的离线申请已经提交,系统已经发送一封邮件给您,请打印出申请表并签字后邮寄给西部数据中心服务组,具体信息请参考邮件说明。' );
$this -> _redirect ( '/data/order' );
}
}
} else {
2012-06-11 11:48:54 +00:00
$sql = " select u.* from users u left join offlineapp o on u.id=o.userid where u.id=? " ;
2011-09-20 02:58:44 +00:00
$row = $this -> db -> fetchRow ( $sql , array ( $userid ));
/* $row = $ut -> fetchRow ( 'id=' . $userid );
$formData [ 'email' ] = $row -> email ;
$formData [ 'phone' ] = $row -> phone ;
$formData [ 'realname' ] = $row -> realname ;
$formData [ 'unit' ] = $row -> unit ;
$formData [ 'address' ] = $row -> address ;
$formData [ 'purpose' ] = $row -> project ;
$formData [ 'id' ] = $row -> id ; */
$this -> view -> form -> populate ( $row );
}
} else
$this -> view -> msg = " 错误:您还没有提交任何离线申请的数据,或您的数据申请已经正式提交(等待处理过程中)! " ;
}
//显示已经申请的数据,包括已经提交的申请和未提交的申请,还有已经处理完成的申请,正在进行的在线数据下载
2012-12-04 06:45:52 +00:00
$sql = " select d.*,m.title,m.datatype from dataorder d left join metadata m on d.uuid=m.uuid where (d.status>0 or (d.status=0 and (d.ts_approved is not null))) and d.userid=? order by d.status,d.ts_created desc " ;
2011-09-20 02:58:44 +00:00
$rows = $this -> db -> fetchAll ( $sql , array ( $userid ));
foreach ( $rows as $row ) {
switch ( $row [ 'status' ]){
case 0 :
$dataorder0 [] = $row ;
break ;
case 1 :
$dataorder1 [] = $row ;
break ;
case 2 :
case 3 :
case 4 :
$dataorder2 [] = $row ;
break ;
case 5 :
$dataorder3 [] = $row ;
break ;
default :
break ;
}
}
@ $this -> view -> dataorder0 = $dataorder0 ;
@ $this -> view -> dataorder1 = $dataorder1 ;
@ $this -> view -> dataorder2 = $dataorder2 ;
@ $this -> view -> dataorder3 = $dataorder3 ;
}
/*
* 查看数据缩略图
*/
function thumbAction ()
{
2012-03-28 14:04:00 +00:00
$page = ( int ) $this -> _request -> getParam ( 'page' );
if ( empty ( $page )) $page = 1 ;
$offset = $this -> limit * ( $page - 1 );
$state = $this -> db -> query ( " select count(*) from normalmetadata " );
$row = $state -> fetchAll ();
$sum = $row [ 0 ][ 'count' ];
$select = $this -> db -> select ();
$select -> from ( 'normalmetadata as m' , 'm.*' )
2013-04-10 08:47:05 +00:00
-> order ( 'm.title desc' ) -> limitPage ( $page , 9 );
2012-03-28 14:04:00 +00:00
$this -> view -> metadata = $this -> db -> fetchAll ( $select );
$this -> view -> page = new Pagination ( $sum , $page , $this -> limit );
2011-09-20 02:58:44 +00:00
}
2011-09-28 09:55:52 +00:00
/*
* 附件下载
*/
function attachAction (){
$uuid = $this -> _request -> getParam ( 'uuid' );
if ( ! empty ( $uuid ))
{
2011-09-28 10:06:17 +00:00
$sql = " select * from mdattach m left join attachments a on m.id=a.id where m.uuid=' $uuid ' " ;
$re = $this -> db -> query ( $sql );
$atts = $re -> fetch ();
if ( empty ( $atts [ 'id' ]))
{
$this -> _redirect ( " /data/ $uuid " );
} //没有附件
2011-09-28 09:55:52 +00:00
$auth = Zend_Auth :: getInstance ();
if ( $auth -> hasIdentity ())
{
/*
$user = $auth -> getIdentity ();
$userid = $user -> id ;
$sql = " select d.* from dataorder d
left join users u on u . id = d . userid
left join metadata m on m . uuid = d . uuid
where ( d . status = 5 and d . userid = '$userid' and d . uuid = '$uuid' ) or u . usertype = 'administrator' " ;
$re = $this -> db -> query ( $sql );
$row = $re -> fetch ();
if ( ! empty ( $row [ 'uuid' ]))
{
$this -> messenger -> addMessage ( '您没有权限下载该附件' );
$this -> _redirect ( " /data " );
}
else
{ */
//由于涉及多个文件下载, 所以将附件添加到zip压缩文件再输出
$sql = " select * from mdattach m left join attachments a on m.id=a.id where m.uuid=' $uuid ' " ;
$re = $this -> db -> query ( $sql );
$atts = $re -> fetchAll ();
$zip = new ZipArchive ();
2011-11-08 04:16:56 +00:00
$url = $this -> view -> config -> upload . " tmp/attachments_ $uuid .zip " ; //创建临时文件
2011-09-28 09:55:52 +00:00
$opened = $zip -> open ( $url , ZIPARCHIVE :: CREATE | ZIPARCHIVE :: OVERWRITE );
if ( $opened !== true ){
die ( " cannot open { $url } for writing. " );
}
$updates = array (); //统计被下载的附件ID
foreach ( $atts as $k => $v )
{
2011-11-08 04:16:56 +00:00
if ( is_file ( $this -> view -> config -> upload . $v [ 'filename' ])) {
2011-09-28 09:55:52 +00:00
$updates [] = $v [ 'id' ];
2011-11-08 04:16:56 +00:00
$zip -> addFile ( $this -> view -> config -> upload . $v [ 'filename' ], '/' . basename ( $v [ 'filename' ]));
2011-09-28 09:55:52 +00:00
}
}
$zip -> close ();
//更新统计
$ids = join ( ',' , $updates );
$sql = " update attachments set downtimes=downtimes+1 where id in ( $ids ) " ;
@ $this -> db -> exec ( $sql );
//输出下载
$content = file_get_contents ( $url );
$this -> _helper -> layout -> disableLayout ();
$this -> _helper -> viewRenderer -> setNoRender ();
$this -> getResponse () -> setHeader ( 'Content-Type' , 'application/octet-stream' )
-> setHeader ( 'Content-Disposition' , 'attachment; filename="' . basename ( $url ) . '"' )
-> setHeader ( 'Content-Length' , strlen ( $content ))
-> setHeader ( 'Content-Type' , 'application/force-download' )
-> setHeader ( 'Content-Type' , 'application/download' )
-> setHeader ( 'Content-Type' , 'application/zip' )
-> setHeader ( 'Content-Description' , 'File Transfer' )
-> setHeader ( 'Content-Transfer-Encoding' , 'binary' )
-> setHeader ( 'Expires' , 0 )
-> setHeader ( 'Cache-Control' , 'must-revalidate, post-check=0, pre-check=0' )
-> setHeader ( 'Pragma' , 'public' )
2011-09-30 08:48:49 +00:00
-> setBody ( $content );
2011-09-28 09:55:52 +00:00
// }
} //end if
else
{
$this -> messenger -> addMessage ( '您没有权限下载该附件' );
2011-09-30 08:48:49 +00:00
$this -> _redirect ( " /data/ $uuid " );
2011-09-28 09:55:52 +00:00
} //未登陆
} //end if
else
{
$this -> messenger -> addMessage ( '您没有权限下载该附件' );
2011-09-30 08:48:49 +00:00
$this -> _redirect ( " /data/ $uuid " );
2011-09-28 09:55:52 +00:00
} //无权限
}
2011-09-20 02:58:44 +00:00
/*
* 西部计划项目及其数据产出
*/
public function westeeAction ()
{
//$sql="select w.*,m.uuid from westee w left join westeemd m on w.id=m.eeid order by w.id";
$sql = " select * from westee order by id " ;
$this -> view -> westee = $this -> db -> fetchAll ( $sql );
$sql = " select w.eeid,m.title,m.uuid from westeemd w left join metadata m on w.uuid=m.uuid order by w.eeid " ;
$this -> view -> westeemd = $this -> db -> fetchAll ( $sql );
}
public function pingbackAction ()
{
$this -> _helper -> ViewRenderer -> setNoRender ();
$this -> _helper -> layout -> disableLayout ();
$server = new Zend_XmlRpc_Server ();
$server -> setClass ( 'PingbackRpc' , 'pingback' );
echo $server -> handle ();
}
public function pingtestAction ()
{
$this -> _helper -> ViewRenderer -> setNoRender ();
$this -> _helper -> layout -> disableLayout ();
$client = new Zend_XmlRpc_Client ( 'http://test.westgis.ac.cn/data/pingback' );
$arg1 = 'http://wlx.westgis.ac.cn/567/' ;
$arg2 = 'http://test.westgis.ac.cn/data/487591d0-d437-4114-b810-cbef7c4ee4b2' ;
//$result = $client->call('pingback.ping', array($arg1, $arg2));
$test = $client -> getProxy ( 'pingback' );
$test -> ping ( $arg1 , $arg2 );
//var_dump($result);
}
public function outputAction ()
{
$this -> _helper -> layout -> disableLayout ();
$this -> _helper -> viewRenderer -> setNoRender ();
2011-10-26 09:28:19 +00:00
$sql = " select title,datatype,filesize,id from normalmetadata " ;
2011-09-20 02:58:44 +00:00
$md = $this -> db -> fetchAll ( $sql );
foreach ( $md as $m )
{
print $m [ " title " ] . " , " ;
print ( $m [ " datatype " ] ? " 内部 " : " 公开 " ) . " , " ;
print ( $m [ " filesize " ] == 1 ? " " : $m [ " filesize " ]) . " , " ;
$sql1 = " select keyword from keyword where id= " . $m [ " id " ] . " and keytype='place' " ;
$kd = $this -> db -> fetchAll ( $sql1 );
foreach ( $kd as $p ) print $p [ " keyword " ] . " " ;
print " , " ;
$sql1 = " select keyword from keyword where id= " . $m [ " id " ] . " and keytype='temporal' " ;
$kd = $this -> db -> fetchAll ( $sql1 );
foreach ( $kd as $p ) print $p [ " keyword " ] . " " ;
print " , " ;
print " <br> " ;
}
2011-09-28 09:55:52 +00:00
}
2013-05-12 10:30:30 +00:00
2012-06-13 04:05:33 +00:00
public function jsonexit ( $data ){
$this -> getResponse () -> setHeader ( 'Content-Type' , 'application/json' ) -> appendBody ( json_encode ( $data , JSON_NUMERIC_CHECK ));
return true ;
2013-04-22 02:35:32 +00:00
}
function organizationAction ()
{
$page = $this -> _request -> getParam ( 'page' );
$name = $this -> _request -> getParam ( 'name' );
$state = $this -> db -> query ( " select distinct responsible.organisation from responsible left join role on role.resid=responsible.id where role.role in ('pointOfContact','resourceProvider','owner') " );
$this -> view -> organisation = $state -> fetchAll ();
if ( ! empty ( $name )) {
$this -> view -> codename = $name ;
$sql = " select distinct m.* from normalmetadata m left join role r on m.uuid=r.uuid left join responsible s on r.resid=s.id where r.role in ('pointOfContact','resourceProvider','owner') and s.organisation=? " ;
2013-04-16 09:38:28 +00:00
$sth = $this -> db -> prepare ( $sql );
$sth -> execute ( array ( $name ));
$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' );
2013-04-22 02:35:32 +00:00
$this -> view -> paginator = $paginator ;
} else {
//提供全部分类列表
}
2013-04-29 16:07:34 +00:00
}
function fundAction ()
{
$id = ( int ) $this -> _request -> getParam ( 'id' );
if ( ! empty ( $id )) {
$sql = " select * from fund where id=? " ;
2013-04-30 01:58:43 +00:00
$this -> view -> fund = $this -> db -> fetchRow ( $sql , array ( $id ));
2013-04-29 16:07:34 +00:00
if ( $this -> view -> fund ) {
$sql = " select distinct m.* from normalmetadata m left join mdfund mf on m.uuid=mf.uuid where mf.fid=? " ;
$sth = $this -> db -> prepare ( $sql );
$sth -> execute ( array ( $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 ;
}
} else {
//提供全部分类列表
2013-04-30 02:18:23 +00:00
$sql = " select f.id,f.title,f.fund_id,f.fund_type,f.ts_created,count(m.id) as datacount,sum(md.filesize) as filesize from fund f left join mdfund m on f.id=m.fid left join metadata md on m.uuid=md.uuid group by f.id,f.title,f.fund_id,f.fund_type,f.ts_created order by f.ts_created desc " ;
2013-04-29 16:07:34 +00:00
$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 ( 'fund-list' );
}
2013-05-12 10:30:30 +00:00
}
//实现基于DOI信息的浏览
function doiAction ()
{
$ac = $this -> _request -> getParam ( 'ac' );
if ( $ac == 'unready' ) {
//列出没有DOI的数据
$sql = " select m.* from normalmetadata m where length(m.doi)<3 and m.uuid not in (select uuid from datadoi) order by m.ts_created desc " ;
$this -> view -> pageID = 'doi-unready' ;
} else if ( $ac == 'prepare' ) {
//列出有DOI但还未进行提交申请的数据
$sql = " select m.* from normalmetadata m where length(m.doi)>3 and m.uuid not in (select uuid from datadoi) order by m.ts_created desc " ;
$this -> view -> pageID = 'doi-prepare' ;
} else if ( $ac == 'unsubmit' ) {
//列出有DOI并计划提交申请的数据
$sql = " select m.*,d.doi as datadoi,date(d.ts_created) as ts_created from normalmetadata m left join datadoi d on m.uuid=d.uuid where length(m.doi)>3 and d.ts_created is not null and d.ts_submitted is null order by d.ts_created desc " ;
$this -> view -> pageID = 'doi-unsubmit' ;
} else if ( $ac == 'submit' ) {
//列出有DOI并计划提交申请的数据
$sql = " select m.*,d.doi as datadoi,date(d.ts_submitted) as ts_submitted from normalmetadata m left join datadoi d on m.uuid=d.uuid where length(m.doi)>3 and d.ts_submitted is not null and d.ts_published is null order by d.ts_submitted desc,d.ts_created desc " ;
$this -> view -> pageID = 'doi-submit' ;
} else if ( $ac == 'publish' || empty ( $ac )) {
//默认: 列出最新发布的DOI数据
$sql = " select m.*,d.doi as datadoi,date(d.ts_submitted) as ts_submitted,date(d.ts_published) as ts_published from normalmetadata m left join datadoi d on m.uuid=d.uuid where length(m.doi)>3 and d.ts_published is not null order by d.ts_published desc,d.ts_submitted desc,d.ts_created desc " ;
$this -> view -> pageID = 'doi-publish' ;
}
$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 ;
2013-05-13 02:32:25 +00:00
}
//基于数据作者的浏览(包括认证后的数据作者以及未认证的数据作者)
function authorAction ()
{
$ac = $this -> _request -> getParam ( 'ac' );
$id = ( int ) $this -> _request -> getParam ( 'id' );
if ( $ac == 'verified' ) {
//已经认证过的数据作者
$this -> view -> pageID = 'author-verified' ;
$this -> view -> ac = 'verified' ;
if ( $id ) {
//列出作者的数据
$sql = " select username,realname from users where id=? " ;
$this -> view -> author = $this -> db -> fetchRow ( $sql , array ( $id ));
$sql = " select m.* from normalmetadata m left join mdauthor a on a.uuid=m.uuid where a.userid=? " ;
$sth = $this -> db -> prepare ( $sql );
$sth -> execute ( array ( $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 ;
} else {
//已经认证过的数据作者
$sql = " select u.username,u.realname,u.id,count(u.id) as count from mdauthor a left join users u on a.userid=u.id where a.status=1 and a.uuid in (select uuid from normalmetadata) group by u.id,u.username,u.realname " ;
$sth = $this -> db -> prepare ( $sql );
$sth -> execute ();
$rows = $sth -> fetchAll ();
$paginator = Zend_Paginator :: factory ( $rows );
$paginator -> setCurrentPageNumber ( $this -> _getParam ( 'page' ));
$paginator -> setItemCountPerPage ( 50 );
$paginator -> setView ( $this -> view );
Zend_View_Helper_PaginationControl :: setDefaultViewPartial ( 'pagination_param.phtml' );
$this -> view -> paginator = $paginator ;
}
} else if ( $ac == 'unverified' || empty ( $ac )) {
//未认证的数据作者
$this -> view -> pageID = 'author-unverified' ;
$this -> view -> ac = 'unverified' ;
if ( $id ) {
//列出数据
$sql = " select individual as username from responsible where id=? " ;
$this -> view -> author = $this -> db -> fetchRow ( $sql , array ( $id ));
$sql = " select distinct m.* from normalmetadata m left join role r on m.uuid=r.uuid left join responsible s on r.resid=s.id where r.role in ('pointOfContact','resourceProvider','owner') and s.id=? " ;
$sth = $this -> db -> prepare ( $sql );
$sth -> execute ( array ( $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 ;
} else {
//列出所有作者
$sql = " select distinct responsible.individual as username,responsible.id from responsible left join role on role.resid=responsible.id where role.role in ('pointOfContact','resourceProvider','owner') " ;
$sth = $this -> db -> prepare ( $sql );
$sth -> execute ();
$rows = $sth -> fetchAll ();
$paginator = Zend_Paginator :: factory ( $rows );
$paginator -> setCurrentPageNumber ( $this -> _getParam ( 'page' ));
$paginator -> setItemCountPerPage ( 50 );
$paginator -> setView ( $this -> view );
Zend_View_Helper_PaginationControl :: setDefaultViewPartial ( 'pagination_param.phtml' );
$this -> view -> paginator = $paginator ;
}
}
2013-05-12 10:30:30 +00:00
}
2011-09-20 02:58:44 +00:00
}