fanbinit/rhymix
1
0
Fork 0
mirror of https://github.com/Lastorder-DC/rhymix.git synced 2026-01-07 02:31:40 +09:00
Code Issues Projects Releases Packages Wiki Activity

기본 마이그레이션용 XML및 ttxml에 대해 importing 100% 가능하도록 수정. importer 0.2 commit

Browse source 
git-svn-id: http://xe-core.googlecode.com/svn/sandbox@3947 201d5d3c-b55e-5fd7-737f-ddc643e51545
This commit is contained in:
zero 2008-03-17 13:41:56 +00:00
parent 1b8c765148
commit c37932cc71
27 changed files with 1593 additions and 1294 deletions
Download patch file Download diff file Expand all files Collapse all files

413
modules/importer/ttimport.class.php Normal file
View file

@ -0,0 +1,413 @@
<?php
/**
* @class ttimport
* @author zero (zero@nzeo.com)
* @brief ttxml import class
**/
@set_time_limit(0);
@require_once('./modules/importer/extract.class.php');
class ttimport {
var $oXmlParser = null;
/**
* @brief module.xml 형식의 데이터 import
**/
function importModule($key, $cur, $index_file, $unit_count, $module_srl, $user_id) {
// 필요한 객체 미리 생성
$this->oXmlParser = new XmlParser();
// 타겟 모듈의 카테고리 정보 구함
$oDocumentModel = &getModel('document');
$category_list = $category_titles = array();
$category_list = $oDocumentModel->getCategoryList($module_srl);
if(count($category_list)) foreach($category_list as $key => $val) $category_titles[$val->title] = $val->category_srl;
// 먼저 카테고리 정보를 입력함
$category_file = preg_replace('/index$/i', 'category', $index_file);
if(file_exists($category_file)) {
$buff = FileHandler::readFile($category_file);
// xmlParser객체 생성
$xmlDoc = $this->oXmlParser->loadXmlFile($category_file);
$categories = $xmlDoc->items->category;
if($categories) {
if(!is_array($categories)) $categories = array($categories);
$oDocumentController = &getController('document');
foreach($categories as $k => $v) {
$category = $v->name->body;
if(!$category || $category_titles[$category]) continue;
$obj = null;
$obj->title = $category;
$obj->module_srl = $module_srl;
$output = $oDocumentController->insertCategory($obj);
}
$oDocumentController = &getController('document');
$oDocumentController->makeCategoryFile($module_srl);
}
@unlink($category_file);
}
$category_list = $category_titles = array();
$category_list = $oDocumentModel->getCategoryList($module_srl);
if(count($category_list)) foreach($category_list as $key => $val) $category_titles[$val->title] = $val->category_srl;
// 관리자 정보를 구함
$oMemberModel = &getModel('member');
$member_info = $oMemberModel->getMemberInfoByUserID($user_id);
if(!$cur) $cur = 0;
// index파일을 염
$f = fopen($index_file,"r");
// 이미 읽혀진 것은 패스
for($i=0;$i<$cur;$i++) fgets($f, 1024);
// 라인단위로 읽어들이면서 $cur보다 커지고 $cur+$unit_count개보다 작으면 중지
for($idx=$cur;$idx<$cur+$unit_count;$idx++) {
if(feof($f)) break;
// 정해진 위치를 찾음
$target_file = trim(fgets($f, 1024));
if(!file_exists($target_file)) continue;
// 이제부터 데이터를 가져오면서 처리
$fp = fopen($target_file,"r");
if(!$fp) continue;
$obj = null;
$obj->module_srl = $module_srl;
$obj->document_srl = getNextSequence();
$obj->uploaded_count = 0;
$files = array();
$started = false;
$buff = null;
// 본문 데이터부터 처리 시작
while(!feof($fp)) {
$str = fgets($fp, 1024);
// 한 아이템 준비 시작
if(substr($str,0,5) == '<post') {
$started = true;
continue;
// 첨부파일 입력
} else if(substr($str,0,12) == '<attachment ') {
if($this->importAttaches($fp, $module_srl, $obj->document_srl, $files, $str)) $obj->uploaded_count++;
continue;
}
if($started) $buff .= $str;
}
$xmlDoc = $this->oXmlParser->parse('<post>'.$buff);
$category = $xmlDoc->post->category->body;
if($category_titles[$category]) $obj->category_srl = $category_titles[$category];
$obj->is_notice = 'N';
$obj->is_secret = $xmlDoc->post->visibility->body=='syndicated'?'N':'Y';
$obj->title = $xmlDoc->post->title->body;
$obj->content = $xmlDoc->post->content->body;
$obj->password = md5($xmlDoc->post->password->body);
//$obj->allow_comment = $xmlDoc->post->acceptComment->body==1?'Y':'N';
$obj->allow_comment = 'Y';
//$obj->allow_trackback = $xmlDoc->post->acceptTrackback->body==1?'Y':'N';
$obj->allow_trackback = 'Y';
$obj->regdate = date("YmdHis",$xmlDoc->post->published->body);
$obj->last_update = date("YmdHis", $xmlDoc->post->modified->body);
if(!$obj->last_update) $obj->last_update = $obj->regdate;
$tag = null;
$tmp_tags = null;
$tag = $xmlDoc->post->tag;
if($tag) {
if(!is_array($tag)) $tag = array($tag);
foreach($tag as $key => $val) $tmp_tags[] = $val->body;
$obj->tags = implode(',',$tmp_tags);
}
$obj->readed_count = 0;
$obj->voted_count = 0;
$obj->nick_name = $member_info->nick_name;
$obj->user_name = $member_info->user_name;
$obj->user_id = $member_info->user_id;
$obj->member_srl = $member_info->member_srl;
$obj->email_address = $member_info->email_address;
$obj->homepage = $member_info->homepage;
$obj->ipaddress = $_REMOTE['SERVER_ADDR'];
$obj->list_order = $obj->update_order = $obj->document_srl*-1;
$obj->lock_comment = 'N';
$obj->notify_message = 'N';
// content 정보 변경 (첨부파일)
$obj->content = str_replace('[##_ATTACH_PATH_##]/','',$obj->content);
if(count($files)) {
foreach($files as $label => $filename) {
$obj->content = preg_replace_callback('!\[##_([a-z0-9]+)\|([^\|]*)\|([^\|]*)\|(.*?)_##\]!is', array($this, '_replaceTTImgTag'), $obj->content);
}
}
if(count($files)) {
foreach($files as $key => $val) {
$obj->content = preg_replace('/(src|href)\=(["\']?)'.preg_quote($key).'(["\']?)/i','$1="'.$val.'"',$obj->content);
}
}
// 역인글 입력
$obj->trackback_count = 0;
if($xmlDoc->post->trackback) {
$trackbacks = $xmlDoc->post->trackback;
if(!is_array($trackbacks)) $trackbacks = array($trackbacks);
if(count($trackbacks)) {
foreach($trackbacks as $key => $val) {
$tobj = null;
$tobj->trackback_srl = getNextSequence();
$tobj->module_srl = $module_srl;
$tobj->document_srl = $obj->document_srl;
$tobj->url = $val->url->body;
$tobj->title = $val->title->body;
$tobj->blog_name = $val->site->body;
$tobj->excerpt = $val->excerpt->body;
$tobj->regdate = date("YmdHis",$val->received->body);
$tobj->ipaddress = $val->ip->body;
$tobj->list_order = -1*$tobj->trackback_srl;
$output = executeQuery('trackback.insertTrackback', $tobj);
if($output->toBool()) $obj->trackback_count++;
}
}
}
// 댓글입력
$obj->comment_count = 0;
if($xmlDoc->post->comment) {
$comment = $xmlDoc->post->comment;
if(!is_array($comment)) $comment = array($comment);
foreach($comment as $key => $val) {
$parent_srl = $this->insertComment($val, $module_srl, $obj->document_srl, 0);
if($parent_srl === false) continue;
$obj->comment_count++;
if($val->comment) {
$child_comment = $val->comment;
if(!is_array($child_comment)) $child_comment = array($child_comment);
foreach($child_comment as $k => $v) {
$result = $this->insertComment($v, $module_srl, $obj->document_srl, $parent_srl);
if($result !== false) $obj->comment_count++;
}
}
}
}
// 문서 입력
$output = executeQuery('document.insertDocument', $obj);
if($output->toBool()) {
// 태그 입력
if($obj->tags) {
$tag_list = explode(',',$obj->tags);
$tag_count = count($tag_list);
for($i=0;$i<$tag_count;$i++) {
$args = null;
$args->tag_srl = getNextSequence();
$args->module_srl = $module_srl;
$args->document_srl = $obj->document_srl;
$args->tag = trim($tag_list[$i]);
$args->regdate = $obj->regdate;
if(!$args->tag) continue;
$output = executeQuery('tag.insertTag', $args);
}
}
}
fclose($fp);
@unlink($target_file);
}
fclose($f);
return $idx-1;
}
/**
* @brief 첨부파일 정리
**/
function importAttaches($fp, $module_srl, $upload_target_srl, &$files, $buff) {
$uploaded_count = 0;
$file_obj = null;
$file_obj->file_srl = getNextSequence();
$file_obj->upload_target_srl = $upload_target_srl;
$file_obj->module_srl = $module_srl;
while(!feof($fp)) {
$str = fgets($fp, 1024);
// </attaches>로 끝나면 중단
if(trim($str) == '</attachment>') break;
// <file>로 시작하면 xml파일내의 첨부파일로 처리
if(substr($str, 0, 9)=='<content>') {
$file_obj->file = $this->saveTemporaryFile($fp, $str);
continue;
}
$buff .= $str;
}
$buff .= '</attachment>';
$xmlDoc = $this->oXmlParser->parse($buff);
$file_obj->source_filename = $xmlDoc->attachment->name->body;
$file_obj->download_count = $xmlDoc->attachment->downloads->body;
$label = $xmlDoc->attachment->label->body;
// 이미지인지 기타 파일인지 체크하여 upload path 지정
if(preg_match("/\.(jpg|jpeg|gif|png|wmv|wma|mpg|mpeg|avi|swf|flv|mp3|asaf|wav|asx|midi|asf)$/i", $file_obj->source_filename)) {
$path = sprintf("./files/attach/images/%s/%s/", $module_srl,$upload_target_srl);
$filename = $path.$file_obj->source_filename;
$file_obj->direct_download = 'Y';
} else {
$path = sprintf("./files/attach/binaries/%s/%s/", $module_srl, $upload_target_srl);
$filename = $path.md5(crypt(rand(1000000,900000), rand(0,100)));
$file_obj->direct_download = 'N';
}
// 디렉토리 생성
if(!FileHandler::makeDir($path)) continue;
@rename($file_obj->file, $filename);
// DB입력
unset($file_obj->file);
$file_obj->uploaded_filename = $filename;
$file_obj->file_size = filesize($filename);
$file_obj->comment = NULL;
$file_obj->member_srl = 0;
$file_obj->sid = md5(rand(rand(1111111,4444444),rand(4444445,9999999)));
$file_obj->isvalid = 'Y';
$output = executeQuery('file.insertFile', $file_obj);
if($output->toBool()) {
$uploaded_count++;
$tmp_obj = null;
$tmp_obj->source_filename = $file_obj->source_filename;
if($file_obj->direct_download == 'Y') $files[$file_obj->source_filename] = $file_obj->uploaded_filename;
else $files[$file_obj->source_filename] = getUrl('','module','file','act','procFileDownload','file_srl',$file_obj->file_srl,'sid',$file_obj->sid);
return true;
}
return false;
}
/**
* @biref 임의로 사용할 파일이름을 return
**/
function getTmpFilename() {
$path = "./files/cache/tmp";
if(!is_dir($path)) FileHandler::makeDir($path);
$filename = sprintf("%s/%d", $path, rand(11111111,99999999));
if(file_exists($filename)) $filename .= rand(111,999);
return $filename;
}
/**
* @brief 특정 파일포인트로부터 key에 해당하는 값이 나타날때까지 buff를 읽음
**/
function saveTemporaryFile($fp, $buff) {
$temp_filename = $this->getTmpFilename();
$buff = substr($buff, 9);
while(!feof($fp)) {
$str = trim(fgets($fp, 1024));
$buff .= $str;
if(substr($str, -10) == '</content>') break;
}
$buff = substr($buff, 0, -10);
$f = fopen($temp_filename, "w");
fwrite($f, base64_decode($buff));
fclose($f);
return $temp_filename;
}
/**
* @brief ttxml의 자체 img 태그를 치환
**/
function _replaceTTImgTag($matches) {
return sprintf("<img src=\"%s\" alt=\"%s\" /><br /><br />", $matches[2], str_replace("\"","\\\"",$matches[4]));
}
/**
* @brief 댓글 입력
**/
function insertComment($val, $module_srl, $document_srl, $parent_srl = 0) {
$tobj = null;
$tobj->comment_srl = getNextSequence();
$tobj->module_srl = $module_srl;
$tobj->document_srl = $document_srl;
$tobj->is_secret = $val->secret->body==1?'Y':'N';
$tobj->notify_message = 'N';
$tobj->content = nl2br($val->content->body);
$tobj->voted_count = 0;
$tobj->password = $val->password->body;
$tobj->nick_name = $val->commenter->name->body;
$tobj->member_srl = 0;
$tobj->homepage = $val->commenter->homepage->body;
$tobj->last_update = $tobj->regdate = date("YmdHis",$val->written->body);
$tobj->ipaddress = $val->commenter->ip->body;
$tobj->list_order = $tobj->comment_srl*-1;
$tobj->sequence = $sequence;
$tobj->parent_srl = $parent_srl;
// 댓글 목록 부분을 먼저 입력
$list_args = null;
$list_args->comment_srl = $tobj->comment_srl;
$list_args->document_srl = $tobj->document_srl;
$list_args->module_srl = $tobj->module_srl;
$list_args->regdate = $tobj->regdate;
// 부모댓글이 없으면 바로 데이터를 설정
if(!$tobj->parent_srl) {
$list_args->head = $list_args->arrange = $tobj->comment_srl;
$list_args->depth = 0;
// 부모댓글이 있으면 부모글의 정보를 구해옴
} else {
// 부모댓글의 정보를 구함
$parent_args->comment_srl = $tobj->parent_srl;
$parent_output = executeQuery('comment.getCommentListItem', $parent_args);
// 부모댓글이 존재하지 않으면 return
if(!$parent_output->toBool() || !$parent_output->data) continue;
$parent = $parent_output->data;
$list_args->head = $parent->head;
$list_args->depth = $parent->depth+1;
if($list_args->depth<2) $list_args->arrange = $tobj->comment_srl;
else {
$list_args->arrange = $parent->arrange;
$output = executeQuery('comment.updateCommentListArrange', $list_args);
if(!$output->toBool()) return $output;
}
}
$output = executeQuery('comment.insertCommentList', $list_args);
if($output->toBool()) {
$output = executeQuery('comment.insertComment', $tobj);
if($output->toBool()) return $tobj->comment_srl;
}
return false;
}
}
?>