<?php
    /**
     * @class  importerAdminController
     * @author zero (zero@nzeo.com)
     * @brief  importer 모듈의 admin controller class
     **/

    class importerAdminController extends importer {

        var $oMemberController = null;
        var $oMemberModel = null;
        var $default_group_srl = 0;

        var $oDocumentController = null;
        var $oDocumentModel = null;
        var $oCommentController = null;
        var $oCommentModel = null;
        var $oTrackbackController = null;

        var $oXmlParser = null;

        /**
         * @brief 초기화
         **/
        function init() {
        }

        /**
         * @brief 회원정보와 게시물 정보를 싱크
         **/
        function procImporterAdminSync() {
            set_time_limit(0);

            // 게시물정보 싱크
            $output = executeQuery('importer.updateDocumentSync');

            // 댓글정보 싱크
            $output = executeQuery('importer.updateCommentSync');

            $this->setMessage('msg_sync_completed');
        }

        /**
         * @brief 회원xml 파일을 분석해서 import
         **/
        function procImporterAdminMemberImport() {
            set_time_limit(0);

            $xml_file = Context::get('xml_file');
            $total_count = (int)Context::get('total_count');
            $success_count = (int)Context::get('success_count');
            $readed_line = (int)Context::get('readed_line');

            // xml_file 경로가 없으면 에러~
            if(!$xml_file) return new Object(-1, 'msg_no_xml_file');

            // local 파일 지정인데 파일이 없으면 역시 에러~
            if(!preg_match('/^http:/i',$xml_file) && (!preg_match("/\.xml$/i", $xml_file) || !file_exists($xml_file)) ) return new Object(-1,'msg_no_xml_file');

            // 이제부터 데이터를 가져오면서 처리
            $fp = $this->getFilePoint($xml_file);
            if(!$fp) return new Object(-1,'msg_no_xml_file');

            // 회원 입력을 위한 기본 객체들 생성
            $this->oMemberController = &getController('member');
            $this->oMemberModel = &getModel('member');

            // 기본 회원 그룹을 구함
            $default_group = $this->oMemberModel->getDefaultGroup();
            $this->default_group_srl = $default_group->group_srl;

            $obj = null;
            $extra_var = null;
            $is_extra_var = false;

            $inserted_count = 0;

            // 본문 데이터부터 처리 시작
            $read_line = 0;
            while(!feof($fp)) {
                $str = trim(fgets($fp, 1024));

                if($str == "</member>") $read_line ++;
                if($read_line < $readed_line) continue;

                // 한 아이템 준비 시작
                if($str == '<member>') {
                    $obj = $extra_var = null;
                    $is_extra_var = false;
                    continue;

                // 추가 변수 시자r 일 경우 
                } elseif($str == '<extra_vars>') {
                    $is_extra_var = true;

                // 추가 변수 종료 일 경우 
                } elseif($str == '</extra_vars>') {
                    $is_extra_var = false;
                    $obj->extra_vars = $extra_var;

                // 아이템 종료시 DB 입력
                } else if( $str == '</member>') {
                    if($this->importMember($obj)) $inserted_count ++;
                    if($inserted_count >= 300) {
                        $manual_break = true;
                        break;
                    }

                // members 태그 체크 (전체 개수를 구함)
                } else if(substr($str,0,8)=='<members') {
                    preg_match('/count="([0-9]+)"/i', $str, $matches);
                    $total_count = $matches[1];
                    continue;

                // 선언구 패스~
                } else if(substr($str,0,5)=='<?xml') {
                    continue;
                    
                // 종료 부분
                } else if($str == '</members>') {
                    break;

                // 이미지 마크, 이미지이름, 프로필 사진일 경우
                } else if(in_array($str, array('<image_mark>','<image_nickname>','<profile_image>'))) {

                    // binary buffer일 경우 임의의 위치에 파일을 저장시켜 놓고 그 파일의 경로를 return
                    $key = substr($str,1,strlen($str)-2);
                    $filename = $this->readFileBuff($fp, $key);
                    $obj->{$key} = $filename;

                // 변수 체크
                } else {
                    $buff .= $str;
                    $pos = strpos($buff, '>');
                    $key = substr($buff, 1, $pos-1);
                    if(substr($buff, -1 * ( strlen($key)+3)) == '</'.$key.'>') {
                        $val = base64_decode(substr($buff, $pos, strlen($buff)-$pos*2-2));
                        if($is_extra_var) $extra_var->{$key} = $val;
                        else $obj->{$key} = $val;
                        $buff = null;
                    }
                }
            }

            fclose($fp);

            $success_count += $inserted_count;

            if($manual_break) {
                $this->add('total_count',$total_count);
                $this->add('success_count',$success_count);
                $this->add('readed_line',$read_line);
                $this->add('is_finished','0');
                $this->setMessage(sprintf(Context::getLang('msg_importing'), $total_count, $success_count));
            } else {
                $this->add('is_finished','1');
                $this->setMessage(sprintf(Context::getLang('msg_import_finished'), $success_count, $total_count));
            }
        }

        /**
         * @brief 주어진 xml 파일을 파싱해서 회원 정보 입력
         **/
        function importMember($obj) {
            // homepage, blog의 url을 정확히 만듬
            if($obj->homepage && !preg_match("/^http:\/\//i",$obj->homepage)) $obj->homepage = 'http://'.$obj->homepage;
            if($obj->blog && !preg_match("/^http:\/\//i",$obj->blog)) $obj->blog = 'http://'.$obj->blog;

            $obj->email_address = $obj->email;
            list($obj->email_id, $obj->email_host) = explode('@', $obj->email);

            if($obj->allow_mailing!='Y') $obj->allow_mailing = 'N';

            $obj->allow_message = 'Y';
            if(!in_array($obj->allow_message, array('Y','N','F'))) $obj->allow_message= 'Y';

            $obj->member_srl = getNextSequence();

            $extra_vars = $obj->extra_vars;
            unset($obj->extra_vars);
            $obj->extra_vars = serialize($extra_vars);

            $output = executeQuery('member.insertMember', $obj);

            // 입력실패시 닉네임 중복인지 확인
            if(!$output->toBool()) {

                // 닉네임 중복이라면 닉네임을 바꾸어서 입력
                $nick_args->nick_name = $obj->nick_name;
                $nick_output = executeQuery('member.getMemberSrl', $nick_args);
                if($nick_ouptut->data->member_srl) {
                    $obj->nick_name .= rand(111,999);
                    $output = executeQuery('member.insertMember', $obj);
                }
            }

            // 입력 성공시
            if($output->toBool()) {

                // 기본 그룹 가입 시킴 
                $obj->group_srl = $this->default_group_srl;
                executeQuery('member.addMemberToGroup',$obj);

                // 이미지네임
                if($obj->image_nickname && file_exists($obj->image_nickname)) {
                    $target_path = sprintf('files/member_extra_info/image_name/%s/', getNumberingPath($obj->member_srl));
                    if(!is_dir($target_path)) FileHandler::makeDir($target_path);
                    $target_filename = sprintf('%s%d.gif', $target_path, $obj->member_srl);
                    @rename($obj->image_nickname, $target_filename);
                }

                // 이미지마크
                if($obj->image_mark && file_exists($obj->image_mark)) {
                    $target_path = sprintf('files/member_extra_info/image_mark/%s/', getNumberingPath($obj->member_srl));
                    if(!is_dir($target_path)) FileHandler::makeDir($target_path);
                    $target_filename = sprintf('%s%d.gif', $target_path, $obj->member_srl);
                    @rename($obj->image_mark, $target_filename);
                }

                // 프로필 이미지
                if($obj->profile_image && file_exists($obj->profile_image)) {
                    $target_path = sprintf('files/member_extra_info/profile_image/%s/', getNumberingPath($obj->member_srl));
                    if(!is_dir($target_path)) FileHandler::makeDir($target_path);
                    $target_filename = sprintf('%s%d.gif', $target_path, $obj->member_srl);
                    @rename($obj->profile_image, $target_filename);
                }

                // 서명
                if($obj->signature) {
                    $signature = removeHackTag($obj->signature);
                    $signature_buff = sprintf('<?php if(!defined("__ZBXE__")) exit();?>%s', $signature);

                    $target_path = sprintf('files/member_extra_info/signature/%s/', getNumberingPath($obj->member_srl));
                    if(!is_dir($target_path)) FileHandler::makeDir($target_path);
                    $target_filename = sprintf('%s%d.signature.php', $target_path, $obj->member_srl);

                    FileHandler::writeFile($target_filename, $signature_buff);
                }
                return true;
            }

            return false;
        }

        /**
         * @brief 메세지xml 파일을 분석해서 import
         **/
        function procImporterAdminMessageImport() {
            set_time_limit(0);

            $xml_file = Context::get('xml_file');
            $total_count = (int)Context::get('total_count');
            $success_count = (int)Context::get('success_count');
            $readed_line = (int)Context::get('readed_line');

            // xml_file 경로가 없으면 에러~
            if(!$xml_file) return new Object(-1, 'msg_no_xml_file');

            // local 파일 지정인데 파일이 없으면 역시 에러~
            if(!preg_match('/^http:/i',$xml_file) && (!preg_match("/\.xml$/i", $xml_file) || !file_exists($xml_file)) ) return new Object(-1,'msg_no_xml_file');

            // 이제부터 데이터를 가져오면서 처리
            $fp = $this->getFilePoint($xml_file);
            if(!$fp) return new Object(-1,'msg_no_xml_file');

            $obj = null;
            $inserted_count = 0;

            // 본문 데이터부터 처리 시작
            $read_line = 0;
            while(!feof($fp)) {
                $str = trim(fgets($fp, 1024));

                if($str == "</message>") $read_line ++;
                if($read_line < $readed_line) continue;

                // 한 아이템 준비 시작
                if($str == '<message>') {
                    $obj = null;
                    continue;

                // 아이템 종료시 DB 입력
                } else if( $str == '</message>') {
                    if($this->importMessage($obj)) $inserted_count ++;
                    if($inserted_count >= 100) {
                        $manual_break = true;
                        break;
                    }

                // messages 태그 체크 (전체 개수를 구함)
                } else if(substr($str,0,9)=='<messages') {
                    preg_match('/count="([0-9]+)"/i', $str, $matches);
                    $total_count = $matches[1];
                    continue;

                // 선언구 패스~
                } else if(substr($str,0,5)=='<?xml') {
                    continue;
                    
                // 종료 부분
                } else if($str == '</messages>') {
                    break;

                // 변수 체크
                } else {
                    $buff .= $str;
                    $pos = strpos($buff, '>');
                    $key = substr($buff, 1, $pos-1);
                    if(substr($buff, -1 * ( strlen($key)+3)) == '</'.$key.'>') {
                        $val = base64_decode(substr($buff, $pos, strlen($buff)-$pos*2-2));
                        if($is_extra_var) $extra_var->{$key} = $val;
                        else $obj->{$key} = $val;
                        $buff = null;
                    }
                }
            }

            fclose($fp);

            $success_count += $inserted_count;

            if($manual_break) {
                $this->add('total_count',$total_count);
                $this->add('success_count',$success_count);
                $this->add('readed_line',$read_line);
                $this->add('is_finished','0');
                $this->setMessage(sprintf(Context::getLang('msg_importing'), $total_count, $success_count));
            } else {
                $this->add('is_finished','1');
                $this->setMessage(sprintf(Context::getLang('msg_import_finished'), $success_count, $total_count));
            }
        }

        /**
         * @brief 주어진 xml 파일을 파싱해서 회원 정보 입력
         **/
        function importMessage($obj) {
            // 보낸이/ 받는이의 member_srl을 구함 (존재하지 않으면 그냥 pass..)
            if(!$obj->sender) return false;
            $sender_args->user_id = $obj->sender;
            $sender_output = executeQuery('member.getMemberInfo',$sender_args);
            $sender_srl = $sender_output->data->member_srl;
            if(!$sender_srl) return false;

            $receiver_args->user_id = $obj->receiver;
            if(!$obj->receiver) return false;
            $receiver_output = executeQuery('member.getMemberInfo',$receiver_args);
            $receiver_srl = $receiver_output->data->member_srl;
            if(!$receiver_srl) return false;

            // 보내는 사용자의 쪽지함에 넣을 쪽지
            $sender_args->sender_srl = $sender_srl;
            $sender_args->receiver_srl = $receiver_srl;
            $sender_args->message_type = 'S';
            $sender_args->title = $obj->title;
            $sender_args->content = $obj->content;
            $sender_args->readed = $obj->readed;
            $sender_args->regdate = $obj->regdate;
            $sender_args->readed_date = $obj->readed_date;
            $sender_args->related_srl = getNextSequence();
            $sender_args->message_srl = getNextSequence();
            $sender_args->list_order = $sender_args->message_srl * -1;

            $output = executeQuery('member.sendMessage', $sender_args);
            if(!$output->toBool()) return false;

            // 받는 회원의 쪽지함에 넣을 쪽지
            $receiver_args->message_srl = $sender_args->related_srl;
            $receiver_args->list_order = $sender_args->related_srl*-1;
            $receiver_args->sender_srl = $sender_srl;
            if(!$receiver_args->sender_srl) $receiver_args->sender_srl = $receiver_srl;
            $receiver_args->receiver_srl = $receiver_srl;
            $receiver_args->message_type = 'R';
            $receiver_args->title = $obj->title;
            $receiver_args->content = $obj->content;
            $receiver_args->readed = $obj->readed;
            $receiver_args->regdate = $obj->regdate;
            $receiver_args->readed_date = $obj->readed_date;
            $output = executeQuery('member.sendMessage', $receiver_args);
            if(!$output->toBool()) return false;

            return true;
        }

        /**
         * @brief module.xml 형식의 데이터 import
         **/
        function procImporterAdminModuleImport() {
            set_time_limit(0);

            $xml_file = Context::get('xml_file');
            $target_module = Context::get('target_module');
            $total_count = (int)Context::get('total_count');
            $success_count = (int)Context::get('success_count');
            $readed_line = (int)Context::get('readed_line');

            // xml_file 경로가 없으면 에러~
            if(!$xml_file) return new Object(-1, 'msg_no_xml_file');

            // local 파일 지정인데 파일이 없으면 역시 에러~
            if(!preg_match('/^http:/i',$xml_file) && (!preg_match("/\.xml$/i", $xml_file) || !file_exists($xml_file)) ) return new Object(-1,'msg_no_xml_file');

            // 필요한 객체 미리 생성
            $this->oDocumentController = &getController('document');
            $this->oDocumentModel = &getModel('document');
            $this->oCommentController = &getController('comment');
            $this->oCommentModel = &getModel('comment');
            $this->oTrackbackController = &getController('trackback');

            // 타켓 모듈의 유무 체크
            if(!$target_module) return new Object(-1,'msg_invalid_request');
            $module_srl = $target_module;

            // 타겟 모듈의 카테고리 정보 구함
            $category_list = $this->oDocumentModel->getCategoryList($module_srl);
            if(count($category_list)) {
                foreach($category_list as $key => $val) $category_titles[$val->title] = $val->category_srl;
            } else {
                $category_list = $category_titles = array();
            }

            // 이제부터 데이터를 가져오면서 처리
            $fp = $this->getFilePoint($xml_file);
            if(!$fp) return new Object(-1,'msg_no_xml_file');

            $manual_break = false;
            $obj = null;
            $document_srl = null;

            $inserted_count = 0;

            // 본문 데이터부터 처리 시작
            $read_line = 0;
            while(!feof($fp)) {
                $str = trim(fgets($fp, 1024));

                if($str == "</post>") $read_line ++;
                if($read_line < $readed_line) continue;

                // 한 아이템 준비 시작
                if(substr($str,0,6) == '<post>') {
                    $obj = null;
                    $obj->module_srl = $module_srl;
                    $obj->document_srl = getNextSequence();
                    continue;

                // 아이템 종료시 DB 입력
                } else if( $str == '</post>') {
                    $obj->member_srl = 0;
                    if($this->importDocument($obj)) $inserted_count ++;
                    if($inserted_count >= 50) {
                        $manual_break = true;
                        break;
                    }

                // posts 태그 체크 (전체 개수를 구함)
                } else if(substr($str,0,6)=='<posts') {
                    preg_match('/count="([0-9]+)"/i', $str, $matches);
                    $total_count = $matches[1];
                    continue;

                // 선언구 패스~
                } else if(substr($str,0,5)=='<?xml') {
                    continue;
                    
                // 종료 부분
                } else if($str == '</posts>') {
                    $manual_break = false;
                    break;

                // 카테고리 입력
                } else if($str == '<categories>') {
                    $this->importCategoris($fp, $module_srl, $category_list, $category_titles);
                    continue;

                // 엮인글 입력
                } else if(substr($str,0,11) == '<trackbacks') {
                    $obj->trackbacks = $this->importTrackbacks($fp);

                // 댓글 입력
                } else if(substr($str,0,9) == '<comments') {
                    $obj->comments = $this->importComments($fp);

                // 첨부파일 입력
                } else if(substr($str,0,9) == '<attaches') {
                    $obj->attaches = $this->importAttaches($fp);

                // 추가 변수 시작 일 경우 
                } elseif($str == '<extra_vars>') {
                    $this->importExtraVars($fp, $obj);

                // 변수 체크
                } else {
                    $buff .= $str;
                    $pos = strpos($buff, '>');
                    $key = substr($buff, 1, $pos-1);
                    if(substr($buff, -1 * ( strlen($key)+3)) == '</'.$key.'>') {
                        $val = base64_decode(substr($buff, $pos, strlen($buff)-$pos*2-2));
                        if($key == 'category' && $category_titles[$val]) $obj->category_srl = $category_titles[$val];
                        else $obj->{$key} = $val;
                        $buff = null;
                    }
                }
            }

            fclose($fp);

            $success_count += $inserted_count;

            if($manual_break) {
                $this->add('total_count',$total_count);
                $this->add('success_count',$success_count);
                $this->add('readed_line',$read_line);
                $this->add('is_finished','0');
                $this->setMessage(sprintf(Context::getLang('msg_importing'), $total_count, $success_count));
            } else {
                $this->add('is_finished','1');
                $this->setMessage(sprintf(Context::getLang('msg_import_finished'), $success_count, $total_count));
            }
        }

        /**
         * @brief 엮인글 정리
         **/
        function importTrackbacks($fp) {
            $trackbacks = array();
            $obj = null;
            while(!feof($fp)) {
                $str = trim(fgets($fp, 1024));
                if($str == '</trackbacks>') break;
                elseif($str == '<trackback>') {
                    $obj = null;
                    continue;

                } elseif($str == '</trackback>') {
                    $trackbacks[] = $obj;
                    continue;
                }

                $buff .= $str;
                $pos = strpos($buff, '>');
                $key = substr($buff, 1, $pos-1);
                if(substr($buff, -1 * ( strlen($key)+3)) == '</'.$key.'>') {
                    $val = base64_decode(substr($buff, $pos, strlen($buff)-$pos*2-2));
                    $obj->{$key} = $val;
                    $buff = null;
                }
            }

            return $trackbacks;
        }

        /**
         * @brief 댓글 정리
         **/
        function importComments($fp) {
            $comments = array();
            $obj = null;
            while(!feof($fp)) {
                $str = trim(fgets($fp, 1024));
                // 댓글 전체 끝
                if($str == '</comments>') break;

                // 개별 댓글 시작
                elseif($str == '<comment>') {
                    $obj = null;
                    continue;

                // 댓글 끝
                } elseif($str == '</comment>') {
                    $comments[] = $obj;
                    continue;

                // 첨부파일이 있을때
                } else if(substr($str,0,9) == '<attaches') {
                    $obj->attaches = $this->importAttaches($fp);
                }

                $buff .= $str;
                $pos = strpos($buff, '>');
                $key = substr($buff, 1, $pos-1);
                if(substr($buff, -1 * ( strlen($key)+3)) == '</'.$key.'>') {
                    $val = base64_decode(substr($buff, $pos, strlen($buff)-$pos*2-2));
                    $obj->{$key} = $val;
                    $buff = null;
                }
            }

            return $comments;
        }

        /**
         * @brief 첨부파일 정리
         **/
        function importAttaches($fp) {
            $attaches = array();
            $obj = null;
            $index = 0;

            while(!feof($fp)) {
                $str = trim(fgets($fp, 1024));
                if($str == '</attaches>') break;
                elseif($str == '<attach>') {
                    $obj = null;
                    continue;

                } elseif($str == '</attach>') {
                    $attaches[] = $obj;
                    continue;

                // 첨부파일
                } else if($str == '<file>') {
                    // binary buffer일 경우 임의의 위치에 파일을 저장시켜 놓고 그 파일의 경로를 return
                    $filename = $this->readFileBuff($fp, 'file');
                    $obj->file = $filename;
                    continue;
                }

                $buff .= $str;
                $pos = strpos($buff, '>');
                $key = substr($buff, 1, $pos-1);
                if(substr($buff, -1 * ( strlen($key)+3)) == '</'.$key.'>') {
                    $val = base64_decode(substr($buff, $pos, strlen($buff)-$pos*2-2));
                    $obj->{$key} = $val;
                    $buff = null;
                }
            }

            return $attaches;
        }

        /**
         * @brief 카테고리 정보 가져오기
         **/
        function importCategoris($fp, $module_srl,  &$category_list, &$category_titles) {
            while(!feof($fp)) {
                $str = trim(fgets($fp, 1024));
                if($str == '</categories>') break;

                $category = base64_decode(substr($str,10,-11));
                if($category_titles[$category]) continue;

                $obj = null;
                $obj->title = $category;
                $obj->module_srl = $module_srl; 
                $output = $this->oDocumentController->insertCategory($obj);
            }

            $category_list = $this->oDocumentModel->getCategoryList($module_srl);
            if(count($category_list)) {
                foreach($category_list as $key => $val) $category_titles[$val->title] = $val->category_srl;
            } else {
                $category_list = $category_titles = array();
            }
        }

        /**
         * @brief 게시글 추가 변수 설정
         **/
        function importExtraVars($fp, &$obj) {
            $index = 1;
            while(!feof($fp)) {
                $str = trim(fgets($fp, 1024));
                if($str == '</extra_vars>') break;

                $buff .= $str;
                $pos = strpos($buff, '>');
                $key = substr($buff, 1, $pos-1);
                if(substr($buff, -1 * ( strlen($key)+3)) == '</'.$key.'>') {
                    $val = base64_decode(substr($buff, $pos, strlen($buff)-$pos*2-2));
                    $obj->{"extra_vars".$index} = $val;
                    $buff = null;
                }
            }
        }

        /**
         * @brief 게시글 입력
         **/
        function importDocument($obj) {
            // 본문, 댓글, 엮인글, 첨부파일별로 변수 정리
            $comments = $obj->comments;
            $trackbacks = $obj->trackbacks;
            $attaches = $obj->attaches;
            unset($obj->comments);
            unset($obj->trackbacks);
            unset($obj->attaches);

            // 첨부파일 미리 등록
            if(count($attaches)) {
                foreach($attaches as $key => $val) {
                    $filename = $val->filename;
                    $download_count = (int)$val->download_count;
                    $file = $val->file;

                    if(!file_exists($file)) continue;

                    $file_info['tmp_name'] = $file;
                    $file_info['name'] = $filename;

                    $oFileController = &getController('file');
                    $file_output = $oFileController->insertFile($file_info, $obj->module_srl, $obj->document_srl, $download_count, true);

                    // 컨텐츠의 내용 수정 (이미지 첨부파일 관련)
                    if($file_output->toBool()) {
                        if($file_output->get('direct_download') == 'Y') {
                            $obj->content = str_replace($filename, sprintf('./files/attach/images/%s/%s/%s', $obj->module_srl, $obj->document_srl, $filename), $obj->content);
                        } else {
                            $oFileModel = &getModel('file');
                            $url = $oFileModel->getDownloadUrl($file_output->get('file_srl'), $file_output->get('sid'));
                            $obj->content = str_replace('"'.$filename.'"', $url, $obj->content);
                        }
                    }
                    @unlink($file);
                }
            }

            // 게시글 등록
            //$obj->member_srl = 0;
            $obj->password_is_hashed = true;
            $output = $this->oDocumentController->insertDocument($obj, true);

            // 등록 실패시 첨부파일을 일단 모두 지움
            if(!$output->toBool()) {
                return false;
            }

            // 댓글 부모/자식 관계 정리하기 위한 변수
            $comment_parent_srls = array();

            // 댓글 등록
            if(count($comments)) {
                $last_comment_updator = '';
                foreach($comments as $key => $val) {
                    // 댓글 내용 정리
                    $comment_args->comment_srl = getNextSequence();
                    $comment_parent_srls[$val->sequence] = $comment_args->comment_srl;
                    if($val->parent) $comment_args->parent_srl = $comment_parent_srls[$val->parent];
                    $comment_args->module_srl = $obj->module_srl;
                    $comment_args->document_srl = $obj->document_srl;
                    $comment_args->content = $val->content;
                    $comment_args->password = $val->password;
                    $comment_args->nick_name = $val->nick_name;
                    $comment_args->user_id = $val->user_id;
                    $comment_args->user_name = $val->user_name;
                    $comment_args->member_srl = 0;
                    $comment_args->email_address = $val->email;
                    $comment_args->homepage = $val->homepage;
                    $comment_args->regdate = $val->regdate;
                    $comment_args->ipaddress = $val->ipaddress;

                    $last_comment_updator = $val->nick_name;

                    // 첨부파일 미리 등록
                    if(count($val->attaches)) {
                        foreach($val->attaches as $k => $v) {
                            $filename = $v->filename;
                            $download_count = (int)$v->download_count;
                            $file = $v->file;

                            if(!file_exists($file)) continue;

                            $file_info['tmp_name'] = $file;
                            $file_info['name'] = $filename;

                            $oFileController = &getController('file');
                            $file_output = $oFileController->insertFile($file_info, $obj->module_srl, $comment_args->comment_srl, $download_count, true);


                            // 컨텐츠의 내용 수정 (이미지 첨부파일 관련)
                            if($file_output->toBool()) {
                                if($file_output->get('direct_download') == 'Y') {
                                    $comment_args->content = str_replace($filename, sprintf('./files/attach/images/%s/%s/%s', $comment_args->module_srl, $comment_args->comment_srl, $filename), $comment_args->content);
                                } else {
                                    $oFileModel = &getModel('file');
                                    $url = $oFileModel->getDownloadUrl($file_output->get('file_srl'), $file_output->get('sid'));
                                    $comment_args->content = str_replace('"'.$filename.'"', $url, $comment_args->content);
                                }
                            }
                            @unlink($file);
                        }
                    }

                    $comment_output = $this->oCommentController->insertComment($comment_args, true);
                }

                // 댓글 수 update
                $comment_count = $this->oCommentModel->getCommentCount($obj->document_srl);
                $update_output = $this->oDocumentController->updateCommentCount($obj->document_srl, $comment_count, $last_comment_updator, true);
            }

            // 엮인글 등록
            if(count($trackbacks)) {
                foreach($trackbacks as $key => $val) {
                    $val->module_srl = $obj->module_srl;
                    $val->document_srl = $obj->document_srl;
                    $val->trackback_srl = getNextSequence();
                    $val->list_order = $val->trackback_srl*-1;
                    $trackback_output = executeQuery('trackback.insertTrackback', $val);
                    //$trackback_output = $this->oTrackbackController->insertTrackback($val, true);
                }
                $oTrackbackModel = &getModel('trackback');
                $trackback_count = $oTrackbackModel->getTrackbackCount($obj->document_srl);
                $this->oDocumentController->updateTrackbackCount($obj->document_srl, $trackback_count);
            }

            return true;
        }


        /**
         * @brief 파일포인터 return (local or http wrapper)
         **/
        function getFilePoint($filename) {
            $fp = null;
            if(preg_match('/^http:/i', $filename)) {
                $url_info = parse_url($filename);
                if(!$url_info['port']) $url_info['port'] = 80;
                if(!$url_info['path']) $url_info['path'] = '/';

                $fp = @fsockopen($url_info['host'], $url_info['port']);
                if($fp) {

                    // 한글 파일이 있으면 한글파일 부분만 urlencode하여 처리 (iconv 필수)
                    $path = $url_info['path'];
                    if(preg_match('/[\xEA-\xED][\x80-\xFF]{2}/', $path)&&function_exists('iconv')) {
                        $path_list = explode('/',$path);
                        $cnt = count($path_list);
                        $filename = $path_list[$cnt-1];
                        $filename = urlencode(iconv("UTF-8","EUC-KR",$filename));
                        $path_list[$cnt-1] = $filename;
                        $path = implode('/',$path_list);
                        $url_info['path'] = $path;
                    }

                    $header = sprintf("GET %s?%s HTTP/1.0\r\nHost: %s\r\nReferer: %s://%s\r\nConnection: Close\r\n\r\n", $url_info['path'], $url_info['query'], $url_info['host'], $url_info['scheme'], $url_info['host']);
                    @fwrite($fp, $header);
                    while(!feof($fp)) {
                        $str = fgets($fp, 1024);
                        if(!trim($str)) break;
                    }
                }
            } else {
                $fp = fopen($filename,"r");
            }

            return $fp;
        }

        /**
         * @biref 임의로 사용할 파일이름을 return
         **/
        function getTmpFilename($key) {
            $path = "./files/cache/tmp";
            if(!is_dir($path)) FileHandler::makeDir($path);
            $filename = sprintf("%s/%s.%d", $path, $key, rand(11111111,99999999));
            if(file_exists($filename)) $filename .= rand(111,999);
            return $filename;
        }

        /**
         * @brief 특정 파일포인트로부터 key에 해당하는 값이 나타날때까지 buff를 읽음
         **/
        function readFileBuff($fp,$key) {
            $temp_filename = $this->getTmpFilename($key);
            $f = fopen($temp_filename, "w");

            $buff = '';
            while(!feof($fp)) {
                $str = trim(fgets($fp, 1024));
                if($str == sprintf('</%s>', $key)) break;

                $buff .= $str;

                if(substr($buff, -7) == '</buff>') {
                    fwrite($f, base64_decode(substr($buff, 6, -7)));
                    $buff = null;
                }
            }
            fclose($f);
            return $temp_filename;
        }

        /**
         * @brief TTXML import
         **/
        function procImporterAdminTTXMLImport() {
            set_time_limit(0);

            $xml_file = Context::get('xml_file');
            $target_module = Context::get('target_module');
            $user_id = Context::get('user_id');
            if(!$user_id) return new Object(-1,'msg_invalid_request');

            $oMemberModel = &getModel('member');
            $member_info = $oMemberModel->getMemberInfoByUserID($user_id);

            $total_count = 0;
            $success_count = 0;

            // xml_file 경로가 없으면 에러~
            if(!$xml_file) return new Object(-1, 'msg_no_xml_file');

            // local 파일 지정인데 파일이 없으면 역시 에러~
            if(!preg_match('/^http:/i',$xml_file) && (!preg_match("/\.xml$/i", $xml_file) || !file_exists($xml_file)) ) return new Object(-1,'msg_no_xml_file');

            // 필요한 객체 미리 생성
            $this->oDocumentController = &getController('document');
            $this->oDocumentModel = &getModel('document');
            $this->oCommentController = &getController('comment');
            $this->oCommentModel = &getModel('comment');
            $this->oTrackbackController = &getController('trackback');

            // 타켓 모듈의 유무 체크
            if(!$target_module) return new Object(-1,'msg_invalid_request');
            $module_srl = $target_module;

            // 타겟 모듈의 카테고리 정보 구함
            $category_list = $this->oDocumentModel->getCategoryList($module_srl);
            if(count($category_list)) {
                foreach($category_list as $key => $val) $category_titles[$val->title] = $val->category_srl;
            } else {
                $category_list = $category_titles = array();
            }

            // 이제부터 데이터를 가져오면서 처리
            $fp = $this->getFilePoint($xml_file);
            if(!$fp) return new Object(-1,'msg_no_xml_file');

            $manual_break = false;
            $obj = null;
            $attaches = array();
            $document_srl = null;

            $inserted_count = 0;

            ob_start();

            $this->oXmlParser = new XmlParser();

            // 본문 데이터부터 처리 시작
            $i=0;
            $started = $category_started = $post_started = false;
            $category_buff = '';
            $manual_break = false;
            while(!$manual_break && !feof($fp)) {
                $str = fgets($fp, 1024);

                if(substr($str,0,7)=='</logs>') $str = substr($str,7);
                if(substr($str,0,6)=='<logs>') $str = substr($str,6);

                if(substr($str,0,10)=='<category>' || substr($str,0,6) == '<post ') $started = true;
                if(!$started) continue;

                // <category가 나오면 카테고리 버퍼링
                if(substr($str,0,10)=='<category>') {
                    $category_started = true;
                    $category_buff .= $str;
                }

                // </post 로 시작시 게시글 버퍼링 중지하고 게시글 등록
                if($post_started && substr($str,0,7)=='</post>') {
                    $str = substr($str,7);

                    // 게시글 처리
                    $post_buff .= '</post>';
                    $xml_doc = $this->oXmlParser->parse($post_buff);
                    $post = $xml_doc->post;

                    if($post->visibility->body=='public') {
                        $obj = null;
                        $obj->module_srl = $module_srl;
                        $obj->document_srl = getNextSequence();
                        $obj->title = $post->title->body;
                        $obj->content = str_replace('[##_ATTACH_PATH_##]/','',$post->content->body);
                        $obj->content = preg_replace_callback('!\[##_1C\|([^\|]*)\|([^\|]*)\|(.*?)_##\]!is', array($this, '_replaceTTImgTag'), $obj->content);
                        $obj->content = nl2br($obj->content);
                        $obj->password = md5($post->password->body);
                        $obj->allow_comment = $post->acceptcomment->body==1?'Y':'N';
                        $obj->allow_trackback= $post->accepttrackback->body==1?'Y':'N';
                        $obj->regdate = date("YmdHis",$post->created->body);
                        $obj->last_update = date("YmdHis",$post->modified->body);

                        $category = trim($post->category->body);
                        if($category) {
                            $tmp_category = explode('/',$category);
                            if(count($tmp_category)>1) $category = $tmp_category[1];
                            $obj->category_srl = (int)$category_titles[$category];
                            if(!$obj->category_srl) {
                                $tmp = array_values($category_titles);
                                $obj->category_srl = (int)$tmp[0];
                            }
                        }
                        $obj->user_id = $member_info->user_id;
                        $obj->nick_name = $member_info->nick_name;
                        $obj->user_name = $member_info->user_name;
                        $obj->member_srl = $member_info->member_srl;

                        // 댓글
                        $obj->comments = $this->importTTComment($post->comment);

                        // 꼬리표
                        $tags = $post->tag;
                        if(!is_array($tags)) $tags = array($tags);
                        if(count($tags)) {
                            $tag_list = array();
                            foreach($tags as $key => $val) {
                                $tag = trim($val->body);
                                if(!$tag) continue;
                                $tag_list[] = $tag;
                            }
                            if(count($tag_list)) $obj->tags = implode(',',$tag_list);
                        }

                        // 엮인글
                        if($post->trackback) {
                            $trackbacks = $post->trackback;
                            if(!is_array($trackbacks)) $trackbacks = array($trackbacks);
                            if(count($trackbacks)) {
                                foreach($trackbacks as $key => $val) {
                                    $tobj = null;
                                    $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;
                                    $obj->trackbacks[] = $tobj;
                                }
                            }
                        }

                        // 첨부파일
                        $obj->attaches = $attaches;

                        $total_count ++;
                        if($this->importDocument($obj)) $success_count ++;
                    }

                    // 새로운 게시글을 위한 처리
                    $post_started = false;
                    $obj = null;
                    $post_buff = '';
                    $attaches = array();

                    // 만약 글입력후 <post로 시작하지 않으면 종료
                    if(substr($str,0,6)!='<post ') $manual_break = true;
                }

                if(!$manual_break) {
                    // <post가 나오면 새로운 게시글 버퍼링 시작, 만약 이전에 카테고리 버퍼링중이였다면 카테고리 처리
                    if(substr($str,0,6)=='<post ') {

                        // 카테고리 버퍼링중이였다면 카테고리 처리
                        if($category_started) {
                            $category_started = false;
                            // 객체 변환후 카테고리 입력
                            $xml_doc = $this->oXmlParser->parse('<categories>'.$category_buff.'</category_buff>');

                            if($xml_doc->category) {
                                $this->insertTTCategory($xml_doc, 0, $module_srl, $category_titles);

                                // 입력완료 후 카테고리 xml파일 재생성
                                $this->oDocumentController->makeCategoryFile($module_srl);
                                $xml_doc = null;
                            }

                            $category_buff = null;
                        }

                        $post_started = true;
                    }

                    // 게시글 버퍼링중일때 처리
                    if($post_started) {
                        // 첨부파일의 경우 별도로 버퍼링을 하지 않고 직접 파일에 기록해야 함
                        if(substr($str,0,12)=='<attachment ') $attaches[] = $this->importTTAttaches($fp, $str);
                        else $post_buff .= $str;
                    }
                }
            }
            fclose($fp);

            $output = ob_get_clean();

            $this->add('is_finished','1');
            $this->add('total_count',$total_count);
            $this->add('success_count',$success_count);
            $this->add('readed_line',0);
            $this->setMessage(sprintf(Context::getLang('msg_import_finished'), $success_count, $total_count));
        }

        /**
         * @brief ttxml의 자체 img 태그를 치환
         **/
        function _replaceTTImgTag($matches) {
            return sprintf("<img src=\"%s\" alt=\"%s\" />", $matches[1], str_replace("\"","\\\"",$matches[3]));
        }

        /**
         * @brief TTXML에 맞게 category정보 입력
         **/
        function insertTTCategory($xml_doc, $parent_srl =0, $module_srl, &$category_titles) {
            // category element가 없으면 pass
            if(!$xml_doc->category) return;
            $categories = $xml_doc->category;

            // 하나만 있을 경우 배열 처리
            if(!is_array($categories)) $categories = array($categories);

            // ttxml에서는 priority순서로 오는게 아니라서 정렬
            foreach($categories as $obj) {
                $title = trim($obj->name->body);
                $priority = $obj->priority->body;
                $root = $obj->root->body;
                if($root==1) continue;
                $category_list[$priority]->title = $title;
                $category_list[$priority]->category = $obj->category;
            }

            // 데이터 입력
            foreach($category_list as $obj) {
                if(!$category_titles[$obj->title]) {
                    $args = null;
                    $args->title = $obj->title;
                    $args->parent_srl = $parent_srl; 
                    $args->module_srl = $module_srl; 
                    $output = $this->oDocumentController->insertCategory($args);
                    if($output->toBool()) $category_titles[$args->title] = $output->get('category_srl');
                    $output = null;
                } 

                $this->insertTTCategory($obj, $category_titles[$obj->title], $module_srl, $category_titles);

            }
        }

        /**
         * @brief TTXML 첨부파일 정리
         **/
        function importTTAttaches($fp, $buff) {
            if(substr(trim($buff), -13) != '</attachment>') {
                while(!feof($fp)) {
                    $buff .= fgets($fp, 1024);
                    if(substr(trim($buff), -13) == '</attachment>') break;
                }
            }

            $xml_doc = $this->oXmlParser->parse($buff);
            $buff = '';

            $obj = null;
            $obj->filename = $xml_doc->attachment->name->body;
            $obj->file = $this->getTmpFilename('file');
            $obj->download_count = $xml_doc->attachment->downloads->body;

            $f = fopen($obj->file, "w");
            fwrite($f, base64_decode($xml_doc->attachment->content->body));
            fclose($f);

            return $obj;
        }

        /**
         * @brief TTXML 댓글 정리
         **/
        function importTTComment($comment) {
            if(!$comment) return;
            if(!is_array($comment)) $comment = array($comment);

            $comments = array();

            $sequence = 0;
            foreach($comment as $key => $val) {
                $obj = null;
                $obj->sequence = $sequence;

                if($val->commenter->attrs->id) $obj->parent = $sequence-1;

                $obj->is_secret = $val->secret->body==1?'Y':'N';
                $obj->content = nl2br($val->content->body);
                $obj->password = $val->password->body;
                $obj->nick_name = $val->commenter->name->body;
                $obj->homepage = $val->commenter->homepage->body;
                $obj->regdate = date("YmdHis",$val->written->body);
                $obj->ipaddress = $val->commenter->ip->body;
                $comments[] = $obj;
                
                $sequence++;
            }
            return $comments;
        }

    }
?>