2009-03-06 03:20:46 +00:00
< ? php
class DataController extends Zend_Controller_Action
{
function __call ( $id , $arguments )
{
Zend_Debug :: dump ( $arguments , 'argu' );
Zend_Debug :: dump ( $id , 'id' );
$this -> _helper -> viewRenderer -> setNoRender ();
$this -> _helper -> layout -> disableLayout ();
}
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 ();
}
function indexAction ()
{
$md = new MetadataTable ();
$db = $md -> getAdapter ();
//序列
$state = $db -> query ( 'select s.id,name,count(*) from series s,dataseries d where d.sid=s.id group by s.id,s.name' );
$this -> view -> serie = $state -> fetchAll ();
//分类
$state = $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' );
$this -> view -> category = $state -> fetchAll ();
//关键词
$state = $db -> query ( 'select keyword,count(*),keytype from keyword group by keyword,keytype order by keytype,count desc' );
$this -> view -> keywords = $state -> fetchAll ();
//最新10个入库数据
$state = $db -> query ( 'select id,uuid,title from metadata order by id desc limit 10' );
$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 ()
{
$this -> view -> addHelperPath ( 'helper' , 'Zend_View_Helper_' );
$searchform = new SearchForm ();
$this -> view -> searchform = $searchform ;
$searchform -> submit -> setLabel ( '快速搜索' );
}
function offlinelistAction ()
{
$this -> view -> addHelperPath ( 'helper' , 'Zend_View_Helper_' );
$searchform = new SearchForm ();
$this -> view -> searchform = $searchform ;
$searchform -> submit -> setLabel ( '快速搜索' );
}
//展示最近20条离线神情记录情况
function offlineappAction ()
{
2009-04-28 11:55:44 +00:00
$sql = " select * from offlineapp where ts_approved is not null order by ts_created desc limit 20 " ;
2009-03-06 03:20:46 +00:00
$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 ()
{
$md = new MetadataTable ();
$db = $md -> getAdapter ();
$page = ( int ) $this -> _request -> getParam ( 'page' );
if ( empty ( $page )) $page = 1 ;
$limit = 10 ;
$offset = $limit * ( $page - 1 );
$state = $db -> query ( 'select count(*) from metadata' );
$row = $state -> fetchAll ();
$sum = $row [ 0 ][ 'count' ];
$select = $db -> select ();
$select -> from ( 'metadata' , '*' ) -> order ( 'id desc' ) -> limitPage ( $page , $limit );
$this -> view -> metadata = $db -> fetchAll ( $select );
$this -> view -> page = new Pagination ( $sum , $page , $limit );
}
function tagAction ()
{
$id = ( int ) $this -> _request -> getParam ( 'id' );
$key = $this -> _request -> getParam ( 'key' );
$md = new KeywordTable ();
$db = $md -> getAdapter ();
$state = $db -> query ( 'select keyword,count(*),keytype from keyword group by keyword,keytype order by keytype,count desc' );
$this -> view -> keywords = $state -> fetchAll ();
if ( $id > 0 or ! empty ( $key )) {
if ( empty ( $key )) {
$where = $db -> quoteInto ( 'id = ?' , $id );
$row = $md -> fetchRow ( $where );
$key = $row -> name ;
}
$this -> view -> codename = $key ;
$sql = $db -> quoteInto ( 'select m.* from metadata m,keyword k where m.id=k.id and k.keyword=?' , $key );
$state = $db -> query ( $sql );
$this -> view -> metadata = $state -> fetchAll ();
}
}
/*
* 数据集序列浏览
*/
function seriesAction ()
{
$id = ( int ) $this -> _request -> getParam ( 'id' );
$md = new SeriesTable ();
$db = $md -> getAdapter ();
$state = $db -> query ( 'select s.id,name,count(*) from series s,dataseries d where d.sid=s.id group by s.id,s.name' );
$this -> view -> serie = $state -> fetchAll ();
if ( $id > 0 ) {
$where = $db -> quoteInto ( 'id = ?' , $id );
$row = $md -> fetchRow ( $where );
$this -> view -> codename = $row -> name ;
$sql = 'select m.* from metadata m,dataseries d where m.id=d.id and d.sid=?' ;
$state = $db -> query ( $sql , array ( $id ));
$this -> view -> metadata = $state -> fetchAll ();
} else {
//提供全部数据集序列列表
}
}
/*
* 分类浏览模式
*/
function categoryAction ()
{
$code = ( int ) $this -> _request -> getParam ( 'code' );
$md = new CategoryCodeTable ();
$db = $md -> getAdapter ();
$state = $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' );
$this -> view -> category = $state -> fetchAll ();
if ( $code > 0 && $code < 20 ) {
$where = $db -> quoteInto ( 'code = ?' , $code );
$row = $md -> fetchRow ( $where );
$this -> view -> codename = ( empty ( $row -> name_zh ) ? $row -> name : $row -> name_zh );
$sql = 'select m.* from metadata m,category c where m.id=c.id and c.code=?' ;
$state = $db -> query ( $sql , array ( $code ));
$this -> view -> metadata = $state -> fetchAll ();
} else {
//提供全部分类列表
}
}
/*
* 时间浏览方式
* todo : 实现xml的缓存
*/
function timelineAction ()
{
$dateformat = " D M j Y G:i:s O " ;
$md = new MetadataTable ();
$db = $md -> getAdapter ();
$state = $db -> query ( 'select id,uuid,title,description,timebegin,timeend from metadata where timebegin is not null' );
$rows = $state -> fetchAll ();
$timexml = '<data>' ;
foreach ( $rows as $row ) {
$timexml .= '<event start="' . date ( $dateformat , strtotime ( $row [ 'timebegin' ])) . '" ' ;
if ( $row [ 'timeend' ] != '' ) $timexml .= ' end="' . date ( $dateformat , strtotime ( $row [ 'timeend' ])) . '" ' ;
$timexml .= ' title="' . $row [ 'title' ] . '" image="/images/westdc_40w.gif" link="/data/' . $row [ 'uuid' ] . '">' . $row [ 'description' ] . '</event>' ;
}
$timexml .= '</data>' ;
$fp = fopen ( 'time.xml' , '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 ; }
$sql = 'select id,west,south,north,east,title from metadata' . $where ;
$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 -> geometry = $box ;
$geomd -> addFeature ( $feature );
}
$this -> _helper -> json ( $geomd );
}
/*
* 返回XML源文件
*/
function xmlAction ()
{
$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 );
$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 ()
);
$sql = " select * from metadata order by ts_created desc " ;
$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 ( '快速搜索' );
if ( $this -> _request -> isPost ()) {
$formData = $this -> _request -> getPost ();
include_once ( " bcspamblock.php " );
if ( bcspamblock_verify () && $form -> isValid ( $formData )) {
$page =@ ( int ) $formData [ 'page' ];
if ( empty ( $page )) $page = 1 ;
$limit = 10 ;
$offset = $limit * ( $page - 1 );
$key = $formData [ 'q' ];
if ( ! empty ( $key )) {
$md = new MetadataTable ();
$db = $md -> getAdapter ();
$sql = $db -> quoteInto ( 'select count(*) from metadata where title ilike ? or description ilike ?' , '%' . $key . '%' , '%' . $key . '%' );
$state = $db -> query ( $sql );
$row = $state -> fetchAll ();
$sum = $row [ 0 ][ 'count' ];
$select = $db -> select ();
$select -> from ( 'metadata' , '*' ) -> where ( 'title ilike ? or description ilike ?' , '%' . $key . '%' , '%' . $key . '%' ) -> order ( 'id desc' ) -> limit ( $limit , $offset );
$this -> view -> metadata = $db -> fetchAll ( $select );
$this -> view -> page = new Pagination ( $sum , $page );
$this -> view -> key = $key ;
}
}
} else {
}
}
/*
* todo : 高级搜索
*/
function advancesearchAction ()
{
$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 ( 'key' );
$searchtype = $this -> _request -> getParam ( 'type' );
if ( ! empty ( $key )) {
$sql = $db -> quoteInto ( 'select count(*) from metadata where title ilike ? or description ilike ?' , '%' . $key . '%' , '%' . $key . '%' );
$state = $db -> query ( $sql );
$row = $state -> fetchAll ();
$sum = $row [ 0 ][ 'count' ];
$select = $db -> select ();
$select -> from ( 'metadata' , '*' ) -> where ( 'title ilike ? or description ilike ?' , '%' . $key . '%' , '%' . $key . '%' ) -> order ( 'id desc' ) -> limit ( $limit , $offset );
$this -> view -> metadata = $db -> fetchAll ( $select );
$this -> view -> page = new Pagination ( $sum , $page );
$this -> view -> key = $key ;
}
}
/*
* 根据id或uuid来查看元数据
* id为一组数字, uuid为唯一标识符
*/
function viewAction ()
{
$md = new MetadataTable ();
$db = $md -> getAdapter ();
$id = ( int ) $this -> _request -> getParam ( 'id' );
if ( empty ( $id )) {
$uuid = $this -> _request -> getParam ( 'uuid' );
if ( empty ( $uuid )) $this -> _redirect ( '/data' );
$where = $db -> quoteInto ( 'uuid = ?' , $uuid );
$row = $md -> fetchRow ( $where );
} else {
$where = $db -> quoteInto ( 'id = ?' , $id );
$row = $md -> fetchRow ( $where );
}
if ( ! $row ) $this -> _redirect ( '/data' );
$id = $row -> id ;
$uuid = $row -> uuid ;
$this -> view -> metadata = $row ;
if ( is_numeric ( $row -> projection ))
{
$sql = " select proj4text from spatial_ref_sys where auth_srid=? " ;
$rs = $db -> fetchRow ( $sql , array (( int ) $row -> projection ));
if ( $rs ) $this -> view -> projection = $rs [ 'proj4text' ];
}
$where = $db -> quoteInto ( 'id= ?' , $id );
$order = 'keytype' ;
$keyt = new KeywordTable ();
$this -> view -> keys = $keyt -> fetchAll ( $where , $order );
$sql = 'select c.code,cc.name,cc.name_zh from category c,categorycode cc where c.code=cc.code and c.id= ?' ;
$state = $db -> query ( $sql , array ( $id ));
$this -> view -> category = $state -> fetchAll ();
$sql = 'select s.name from dataseries d, series s where d.sid=s.id and d.id= ?' ;
$state = $db -> query ( $sql , array ( $id ));
$this -> view -> series = $state -> fetchAll ();
$sql = $db -> quoteInto ( " select count(*) as count from dataorder where uuid=? " , $uuid );
$row = $db -> fetchRow ( $sql );
$this -> view -> downloaded = $row [ 'count' ];
//update the viewed times
$sql = " update mdstat set viewed=viewed+1 where uuid=? " ;
$db -> query ( $sql , array ( $uuid ));
$sql = $db -> quoteInto ( " select viewed from mdstat where uuid=? " , $uuid );
$row = $db -> fetchRow ( $sql );
$this -> view -> viewed = $row [ 'viewed' ];
//相关元数据,根据同名关键词实现
//$sql="select distinct(md.uuid),md.title from keyword kw left join metadata 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";
$sql = " select distinct(md.uuid),md.title from keyword kw left join metadata 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 kw.id<>? limit 10 " ;
$this -> view -> related = $this -> db -> fetchAll ( $sql , array ( $id , $id ));
//相关文献
$sql = " select * from knl_article where " ;
foreach ( $this -> view -> keys as $k )
{
if ( $k -> keytype == 'theme' )
{
$sql .= " title like '% " . $k -> keyword . " %' or " ;
}
}
$sql .= " 1<>1 limit 10 " ;
$this -> view -> literature = $this -> db -> fetchAll ( $sql );
//数据评论
$sql = " select * from comments where uuid=? order by id desc " ;
$this -> view -> comments = $this -> db -> fetchAll ( $sql , array ( $uuid ));
$user = Zend_Auth :: getInstance () -> getIdentity ();
$commentForm = new CommentForm ();
$formdata [ 'uuid' ] = $uuid ;
$formdata [ 'id' ] = 0 ; //用户ID, 默认为0, 即未登录用户
$this -> view -> addHelperPath ( 'helper' , 'Zend_View_Helper_' );
if ( $this -> _request -> isPost ()) {
include_once ( " bcspamblock.php " );
$formdata = $this -> _request -> getPost ();
2009-05-06 03:54:42 +00:00
if ( $user ) {
$formdata [ 'id' ] = $user -> id ;
$formdata [ 'author' ] = $user -> username ;
$formdata [ 'email' ] = $user -> email ;
}
2009-03-06 03:20:46 +00:00
if ( bcspamblock_verify () && $commentForm -> isValid ( $formdata )) {
$sql = " insert into comments (userid,uuid,author,email,url,ip,content,agent,type) values(?,?,?,?,?,?,?,?,?) " ;
$agent = $this -> _request -> getHeader ( 'User-Agent' );
$ip = $this -> _request -> getServer ( 'REMOTE_ADDR' );
$type = 'comment' ;
$stripper = new Zend_Filter_StripTags ( 'strong' ); //剔除特殊字符HTML
$content = $stripper -> filter ( $formdata [ 'content' ]);
$author = $stripper -> filter ( $formdata [ 'author' ]);
$this -> db -> query ( $sql , array ( $formdata [ 'id' ], $formdata [ 'uuid' ], $author , $formdata [ 'email' ], $formdata [ 'url' ], $ip , $content , $agent , $type ));
$formdata [ 'content' ] = '' ;
}
2009-05-06 03:54:42 +00:00
}
if ( $user ) {
$formdata [ 'id' ] = $user -> id ;
$formdata [ 'author' ] = $user -> username ;
$formdata [ 'email' ] = $user -> email ;
2009-03-06 03:20:46 +00:00
}
$commentForm -> populate ( $formdata );
$this -> view -> commentForm = $commentForm ;
//metadata,keyword,series,category,
}
/*
* 数据评论, 根据UUID读取
*/
function commentAction ()
{
$this -> _helper -> layout -> disableLayout ();
$this -> _helper -> viewRenderer -> setNoRender ();
$uuid = $this -> _request -> getParam ( 'uuid' );
if ( empty ( $uuid )) die ();
$sql = " select * from comments where uuid=? order by id desc " ;
$comments = $this -> db -> fetchAll ( $sql , array ( $uuid ));
if ( $comments )
{
foreach ( $comments as $c )
{
//$author=$this->view->escape($c['author']);
$author = $c [ 'author' ];
$author = ( $c [ 'userid' ]) ? " <strong> " . $author . " </strong> " : $author ;
$author = ( $c [ 'url' ]) ? '<a href="' . $c [ 'url' ] . '">' . $author . '</a>' : $author ;
print " <div class='comment-content'><span> " . $author . " 发表于 " . date ( 'Y-m-d H:i:s' , strtotime ( $c [ 'ts_created' ])) . " </span><p> " . ( $c [ 'content' ]) . " </p></div> " ;
}
} //else echo "<li>No comments.</li>";
}
/*
* 数据下载, 根据UUID进行判断
2009-03-08 02:57:48 +00:00
* 一次只下载一个数据(一个元数据项)
2009-03-06 03:20:46 +00:00
*/
function downloadAction ()
{
$uuid = $this -> _request -> getParam ( 'uuid' );
if ( empty ( $uuid )) $this -> _redirect ( '/data' );
$userid = Zend_Auth :: getInstance () -> getIdentity () -> id ;
2009-03-20 05:36:25 +00:00
$this -> view -> username = 'westdc' . Zend_Auth :: getInstance () -> getIdentity () -> id ;
2009-03-06 03:20:46 +00:00
$sql = $this -> db -> quoteInto ( " select o.* from onlineresource o left join metadata m on o.uuid=m.uuid where m.datatype=0 and m.uuid=? " , $uuid );
$rows = $this -> db -> fetchAll ( $sql );
$updateftp = $updateftp1 = false ;
$sql = $this -> db -> quoteInto ( " select * from metadata where uuid=? " , $uuid );
$this -> view -> md = $this -> db -> fetchRow ( $sql );
$bigfile = ( $this -> view -> md [ 'filesize' ] > 5 );
$this -> view -> userpass = md5 ( 'westdc' . rand ( 1000 , 9999 ));
$this -> view -> ftptime = date ( 'Y-m-d H:i:s' , strtotime ( '+1 week' ));
2009-03-08 02:57:48 +00:00
$sql = $this -> db -> quoteInto ( " select * from ftpuser where userid=? " , $userid );
$row = $this -> db -> fetchRow ( $sql );
2009-03-14 07:01:11 +00:00
$datacount = $row [ 'datacount' ];
2009-03-06 03:20:46 +00:00
foreach ( $rows as $row ) {
$url = $row [ 'linkage' ];
$p = parse_url ( $url );
if ( $p [ 'scheme' ] == 'ftp' )
//if ($row['protocol']=="WWW:DOWNLOAD-1.0-ftp--download")
{
//判断FTP URL是否附带了用户名和密码
if ( $p [ 'host' ] == 'ftp.westgis.ac.cn' )
$url = 'ftp://' . $this -> view -> config -> ftp -> user . ':' . $this -> view -> config -> ftp -> password . '@ftp.westgis.ac.cn' . $p [ 'path' ];
if ( ! $bigfile && is_file ( $url ) && file_exists ( $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' , filesize ( $url ))
-> setHeader ( 'Content-Type' , 'application/force-download' )
-> setHeader ( 'Content-Type' , 'application/download' )
-> 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' )
-> setBody ( file_get_contents ( $url ));
} else {
//是一个FTP, 返回用户名称和密码说明
2009-03-08 02:57:48 +00:00
if ( $p [ 'host' ] == 'ftp.westgis.ac.cn' )
2009-03-06 03:20:46 +00:00
{
//添加FTP帐号信息以及时间控制信息, 只更新一次
$updateftp = true ;
$g6 = new G6ftp ();
$g6 -> db = $this -> db ;
//不进行判断,每个元数据中的下载地址都对应一个虚拟路径
//if (is_file($url)) $path=dirname($p['path']); else $path[]=$p['path'];
$path [] = $p [ 'path' ];
$uu = ( object ) array ( " id " => $userid ,
" username " => $this -> view -> username ,
" password " => $this -> view -> userpass ,
" path " => $path ,
" maxdata " => $this -> view -> config -> download -> max ,
2009-03-08 02:57:48 +00:00
" time " => $this -> view -> ftptime ,
" datacount " => $datacount );
2009-03-06 03:20:46 +00:00
if ( $g6 -> createuser ( $uu )) {
$this -> view -> userpass = $g6 -> pwd ;
$this -> view -> ftptime = $g6 -> time ;
} else {
$this -> messenger -> addMessage ( '错误:您正在进行下载的在线数据数已经超过系统允许的最大值,请在下面点击“完成”或“取消”对应的在线数据下载!' );
$this -> _redirect ( '/data/order' );
}
} elseif ( ! $updateftp1 && $p [ 'host' ] == 'ftp1.westgis.ac.cn' )
{
//添加FTP1帐号信息以及时间控制信息, 只更新一次
$updateftp1 = true ;
}
if ( $p [ 'host' ] == 'ftp.westgis.ac.cn' )
{
//更新URL
$ftpurls [] = 'ftp://' . $this -> view -> username . '@ftp.westgis.ac.cn' . $p [ 'path' ];
} elseif ( $p [ 'host' ] == 'ftp1.westgis.ac.cn' )
$ftpurls [] = 'ftp://ftp1.westgis.ac.cn' . $p [ 'path' ];
else
$ftpurls [] = $url ;
}
} else {
//若不清楚协议,只是列出来?
$links [] = $row ;
}
}
//设置输出
//if ($updateftp || $updateftp1) $this->view->userpass=$password;
@ $this -> view -> ftpurls = $ftpurls ;
@ $this -> view -> links = $links ;
//更新下载记录
//todo: 尝试添加一个RULE: 若有对应数据存在, 则不插入( userid,uuid,status=0,ts_approved:null)
$sql = " select * from dataorder where userid=? and uuid=? and status=0 and (ts_approved is null) " ;
$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 ));
}
}
/*
* 离线申请(可以包括在线数据),在无数据参数时,则显示已有列表
*/
function orderAction ()
{
$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: 取消了在线下载进程
//首先判断离线申请的数据数量是否超过系统限制
$sql = " select count(*) as datacount from dataorder where (ts_approved is null) and userid=? and status>0 and status<6 " ;
$r = $this -> db -> fetchRow ( $sql , array ( $userid ));
if ( $r [ 'datacount' ] < $this -> view -> config -> download -> max ) {
$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 {
$this -> view -> msg = " 错误:您正在进行的离线申请的数据数已经超过系统允许的最大值,请在完成本次离线申请后再进行操作! " ;
}
} elseif ( $del ) {
//删除数据申请
$sql = $this -> db -> quoteInto ( " delete from dataorder where id=? " , $del );
$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 ));
$sql = " update ftpuser set datacount=datacount-1 where userid=? " ;
$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 {
$sql = " update dataorder set ts_approved=now(),status=-1 where status=0 and userid=? and id=? " ;
$this -> db -> query ( $sql , array ( $userid ,( int ) $cancel ));
$sql = " update ftpuser set datacount=datacount-1 where userid=? " ;
$this -> db -> query ( $sql , array ( $userid ));
}
} elseif ( $pdf ) {
//生成PDF离线申请文件
//用户信息可以从SESSION中读取? 离线申请信息
//$sql="select * from users where id=?";
$sql = " select m.title||'('||m.filesize::text||'MB)' as title 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 " ;
$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 ) {
$sql = " update offlineapp set username=?,email=?,phone=?,address=?,postcode=?,project=?,unit=?,datalist=?,ts_created=now() where id=? " ;
$this -> db -> query ( $sql , array ( $formData [ 'realname' ], $formData [ 'email' ], $formData [ 'phone' ], $formData [ 'address' ], $formData [ 'postcode' ], $formData [ 'project' ], $formData [ 'unit' ], $datalist , $row [ 'id' ]));
} else {
2009-03-13 02:41:26 +00:00
$sql = " insert into offlineapp (userid,username,email,phone,address,postcode,project,unit,datalist) values(?,?,?,?,?,?,?,?,?) " ;
2009-03-06 03:20:46 +00:00
$this -> db -> query ( $sql , array ( $userid , $formData [ 'realname' ], $formData [ 'email' ], $formData [ 'phone' ], $formData [ 'address' ], $formData [ 'postcode' ], $formData [ 'project' ], $formData [ 'unit' ], $datalist ));
}
2009-03-13 02:41:26 +00:00
$this -> _helper -> layout -> disableLayout ();
$this -> _helper -> viewRenderer -> setNoRender ();
2009-03-06 03:20:46 +00:00
//生成PDF
$pdf = new ApplicantPDF ();
$pdf -> template = $this -> view -> config -> offline -> template ;
$pdf -> data = $formData ;
$pdf -> drawWestdc ();
header ( " Content-Disposition: inline; filename=result.pdf " );
header ( " Content-Type:application/pdf " );
//header("Content-Length: " . strlen($pdfstring));
2009-03-13 02:41:26 +00:00
echo $pdf -> Output ( 'westdc-data-apply.pdf' , 'S' );
die ();
//exit;
2009-03-06 03:20:46 +00:00
} elseif ( $formData [ 'submit' ]) {
//提交
//生成PDF
$pdf = new ApplicantPDF ();
$pdf -> template = $this -> view -> config -> offline -> template ;
$pdf -> data = $formData ;
$pdf -> drawWestdc ();
$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 ) {
$sql = " update offlineapp set username=?,email=?,phone=?,address=?,postcode=?,project=?,unit=?,datalist=?,ts_created=now(),pdflink=? where id=? " ;
$this -> db -> query ( $sql , array ( $formData [ 'realname' ], $formData [ 'email' ], $formData [ 'phone' ], $formData [ 'address' ], $formData [ 'postcode' ], $formData [ 'project' ], $formData [ 'unit' ], $datalist , $fn , $row [ 'id' ]));
} else {
2009-03-13 02:41:26 +00:00
$sql = " insert into offlineapp (userid,username,email,phone,address,postcode,project,unit,datalist,pdflink) values(?,?,?,?,?,?,?,?,?,?) " ;
2009-03-06 03:20:46 +00:00
$this -> db -> query ( $sql , array ( $userid , $formData [ 'realname' ], $formData [ 'email' ], $formData [ 'phone' ], $formData [ 'address' ], $formData [ 'postcode' ], $formData [ 'project' ], $formData [ 'unit' ], $datalist , $fn ));
}
$sql = " update dataorder set status=3 where status=2 and userid=? " ;
$this -> db -> query ( $sql , array ( $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 -> addHeader ( 'Reply-To' , $this -> view -> config -> service -> email );
$mail -> setFrom ( $this -> view -> config -> service -> email , '西部数据中心服务组' );
$attach = $mail -> createAttachment ( $pdf -> Output ( 'applicant' , 'S' ));
$attach -> filename = '数据申请-' . $formData [ 'realname' ] . '.pdf' ;
/* $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 ();
//跳转到/data/order, 并提示帮助信息, 告知用户已经发送EMAIL
$this -> messenger -> addMessage ( '提示信息:您的离线申请已经提交,系统已经发送一封邮件给您,请打印出申请表并签字后邮寄给西部数据中心服务组,具体信息请参考邮件说明。' );
$this -> _redirect ( '/data/order' );
}
}
} else {
$sql = " select u.*,o.postcode from users u left join offlineapp o on u.id=o.userid where u.id=? " ;
$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 = " 错误:您还没有提交任何离线申请的数据,或您的数据申请已经正式提交(等待处理过程中)! " ;
}
//显示已经申请的数据,包括已经提交的申请和未提交的申请,还有已经处理完成的申请,正在进行的在线数据下载
$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 null))) and d.userid=? order by d.status,d.ts_created desc " ;
$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 :
case 5 :
$dataorder2 [] = $row ;
break ;
default :
$dataorder3 [] = $row ;
break ;
}
}
@ $this -> view -> dataorder0 = $dataorder0 ;
@ $this -> view -> dataorder1 = $dataorder1 ;
@ $this -> view -> dataorder2 = $dataorder2 ;
@ $this -> view -> dataorder3 = $dataorder3 ;
}
/*
* 查看数据缩略图
*/
function thumbAction ()
{
$id = ( int ) $this -> _request -> getParam ( 'id' );
if ( $id > 0 ) {
$md = new ThumbnailTable ();
$thumb = $md -> fetchRow ( 'id=' . $id );
$this -> _helper -> layout -> disableLayout ();
$this -> _helper -> viewRenderer -> setNoRender ();
if ( empty ( $thumb -> data )) {
header ( " Content-Type:image/png " );
header ( " Content-Length: " . filesize ( " images/nothumb.png " ));
$file = fopen ( " images/nothumb.png " , 'r' );
fpassthru ( $file );
exit ;
} else {
header ( " Content-Type:image/ " . $thumb -> filetype );
print base64_decode ( $thumb -> data );
}
}
}
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);
}
}