rhymix/modules/issuetracker/issuetracker.controller.php

<?php
    /**
     * @class  issuetrackerController
     * @author zero (zero@nzeo.com)
     * @brief  issuetracker 모듈의 Controller class
     **/

    class issuetrackerController extends issuetracker {

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

        function procIssuetrackerInsertIssue() {
            // 권한 체크
            if(!$this->grant->ticket_write) return new Object(-1, 'msg_not_permitted');

            // 글작성시 필요한 변수를 세팅
            $obj = Context::getRequestVars();
            $obj->module_srl = $this->module_srl;

            if(!$obj->title) $obj->title = cut_str(strip_tags($obj->content),20,'...');

            // 관리자가 아니라면 게시글 색상/굵기 제거
            if(!$this->grant->manager) {
                unset($obj->title_color);
                unset($obj->title_bold);
            }

            if($obj->occured_version_srl == 0)
            {
                unset($obj->occured_version_srl);
            }

            // document module의 model 객체 생성
            $oDocumentModel = &getModel('document');

            // document module의 controller 객체 생성
            $oDocumentController = &getController('document');

            // 이미 존재하는 글인지 체크
            $oDocument = $oDocumentModel->getDocument($obj->document_srl, $this->grant->manager);

            // 이미 존재하는 경우 수정
            if($oDocument->isExists() && $oDocument->document_srl == $obj->document_srl) {
                $output = $oDocumentController->updateDocument($oDocument, $obj);
                $msg_code = 'success_updated';

                if(!$output->toBool()) return $output;

            // 그렇지 않으면 신규 등록
            } else {
                // transaction start
                $oDB = &DB::getInstance();
                $oDB->begin();

                $output = executeQuery("issuetracker.insertIssue", $obj); 
                if(!$output->toBool()) {
                    $oDB->rollback();
                    return $output;
                }

                $output = $oDocumentController->insertDocument($obj);
                $msg_code = 'success_registed';
                $obj->document_srl = $output->get('document_srl');

                if(!$output->toBool()) {
                    $oDB->rollback();
                    return $output;
                }

                $oDB->commit();

                // 문제가 없고 모듈 설정에 관리자 메일이 등록되어 있으면 메일 발송
                if($output->toBool() && $this->module_info->admin_mail) {
                    $oMail = new Mail();
                    $oMail->setTitle($obj->title);
                    $oMail->setContent( sprintf("From : <a href=\"%s\">%s</a><br/>\r\n%s", getUrl('','document_srl',$obj->document_srl), getUrl('','document_srl',$obj->document_srl), $obj->content));
                    $oMail->setSender($obj->user_name, $obj->email_address);

                    $target_mail = explode(',',$this->module_info->admin_mail);
                    for($i=0;$i<count($target_mail);$i++) {
                        $email_address = trim($target_mail[$i]);
                        if(!$email_address) continue;
                        $oMail->setReceiptor($email_address, $email_address);
                        $oMail->send();
                    }
                }
            }

            // 오류 발생시 멈춤
            if(!$output->toBool()) return $output;

            // 결과를 리턴
            $this->add('mid', Context::get('mid'));
            $this->add('document_srl', $output->get('document_srl'));

            // 성공 메세지 등록
            $this->setMessage($msg_code);
        }

        function procIssuetrackerDeleteIssue() {
            // 문서 번호 확인
            $document_srl = Context::get('document_srl');

            // 문서 번호가 없다면 오류 발생
            if(!$document_srl) return $this->doError('msg_invalid_document');

            // document module model 객체 생성
            $oDocumentController = &getController('document');

            // 삭제 시도
            $output = $oDocumentController->deleteDocument($document_srl, $this->grant->manager);
            if(!$output->toBool()) return $output;

            // 이슈 삭제
            $args->target_srl = $document_srl;
            $output = executeQuery('issuetracker.deleteIssue', $args);

            // 성공 메세지 등록
            $this->add('mid', Context::get('mid'));
            $this->add('page', $output->get('page'));
            $this->setMessage('success_deleted');
        }

        function procIssuetrackerInsertHistory() {
            // 권한 체크
            if(!$this->grant->ticket_write && !$this->grant->commiter) return new Object(-1, 'msg_not_permitted');

            // 원 이슈를 가져옴
            $target_srl = Context::get('target_srl');
            $oIssuetrackerModel = &getModel('issuetracker');
            $oIssue = $oIssuetrackerModel->getIssue($target_srl);
            if(!$oIssue->isExists()) return new Object(-1,'msg_not_founded');

            // 로그인 정보
            $logged_info = Context::get('logged_info');

            // 글작성시 필요한 변수를 세팅
            $args->target_srl = $target_srl;
            $args->content = Context::get('content');
            if($logged_info->member_srl) {
                $args->member_srl = $logged_info->member_srl;
                $args->nick_name = $logged_info->nick_name;
            } else {
                $args->nick_name = Context::get('nick_name');
                $args->password = md5(Context::get('password'));
            }

            // 커미터일 경우 각종 상태 변경값을 받아서 이슈의 상태를 변경하고 히스토리 생성
            if($this->grant->commiter) {
                $milestone_srl = Context::get('milestone_srl');
                $priority_srl = Context::get('priority_srl');
                $type_srl = Context::get('type_srl');
                $component_srl = Context::get('component_srl');
                $package_srl = Context::get('package_srl');
                $occured_version_srl = Context::get('occured_version_srl');
                $action = Context::get('action');
                $status = Context::get('status');
                $assignee_srl = Context::get('assignee_srl');

                $project = $oIssuetrackerModel->getProjectInfo($this->module_srl);
                $history = array();
                $change_args = null;

                if($milestone_srl != $oIssue->get('milestone_srl')) {
                    $new_milestone = null;
                    if(count($project->milestones)) {
                        foreach($project->milestones as $val) {
                            if($val->milestone_srl == $milestone_srl) {
                                $new_milestone = $val;
                                break;
                            }
                        }
                    }

                    if($milestone_srl == 0)
                    {
                        $new_milestone->title = "";
                    }

                    if($new_milestone) {
                        $history['milestone'] = array($oIssue->getMilestoneTitle(), $new_milestone->title);
                        $change_args->milestone_srl = $milestone_srl;
                    }
                }

                if($priority_srl != $oIssue->get('priority_srl')) {
                    $new_priority = null;
                    if(count($project->priorities)) {
                        foreach($project->priorities as $val) {
                            if($val->priority_srl == $priority_srl) {
                                $new_priority = $val;
                                break;
                            }
                        }
                    }

                    if($new_priority) {
                        $history['priority'] = array($oIssue->getPriorityTitle(), $new_priority->title);
                        $change_args->priority_srl = $priority_srl;
                    }
                }

                if($type_srl != $oIssue->get('type_srl')) {
                    $new_type = null;
                    if(count($project->types)) {
                        foreach($project->types as $val) {
                            if($val->type_srl == $type_srl) {
                                $new_type = $val;
                                break;
                            }
                        }
                    }

                    if($new_type) {
                        $history['type'] = array($oIssue->getTypeTitle(), $new_type->title);
                        $change_args->type_srl = $type_srl;
                    }
                }

                if($component_srl != $oIssue->get('component_srl')) {
                    $new_component = null;
                    if(count($project->components)) {
                        foreach($project->components as $val) {
                            if($val->component_srl == $component_srl) {
                                $new_component = $val;
                                break;
                            }
                        }
                    }

                    if($new_component) {
                        $history['component'] = array($oIssue->getComponentTitle(), $new_component->title);
                        $change_args->component_srl = $component_srl;
                    }
                }

                if($package_srl != $oIssue->get('package_srl')) {
                    $new_package = null;
                    if(count($project->packages)) {
                        foreach($project->packages as $val) {
                            if($val->package_srl == $package_srl) {
                                $new_package = $val;
                                break;
                            }
                        }
                    }

                    if($new_package) {
                        $history['package'] = array($oIssue->getPackageTitle(), $new_package->title);
                        $change_args->package_srl = $package_srl;
                    }
                }

                if($occured_version_srl != $oIssue->get('occured_version_srl')) {
                    $new_release = null;
                    if(count($project->releases)) {
                        foreach($project->releases as $val) {
                            if($val->release_srl == $occured_version_srl) {
                                $new_release = $val;
                                break;
                            }
                        }
                    }

                    if($new_release) {
                        $history['occured_version'] = array($oIssue->getReleaseTitle(), $new_release->title);
                        $change_args->occured_version_srl = $occured_version_srl;
                    }
                }

                $status_lang = Context::getLang('status_list');
                switch($action) {
                    case 'resolve' :
                            $history['status'] = array($oIssue->getStatus(), $status_lang[$status]);
                            $change_args->status = $status;
                        break;
                    case 'reassign' :
                            $oMemberModel = &getModel('member');
                            $member_info = $oMemberModel->getMemberInfoByMemberSrl($assignee_srl);
                            $history['assignee'] = array($oIssue->get('assignee_srl'), $member_info->nick_name);
                            $change_args->assignee_srl = $assignee_srl;
                            $change_args->assignee_name = $member_info->nick_name;

                            if($oIssue->get('status')!='assign') {
                                $change_args->status = 'assign';
                                $history['status'] = array($oIssue->getStatus(), $status_lang[$change_args->status]);
                                $change_args->status = $change_args->status;
                            }
                        break;
                    case 'accept' :
                            $history['assignee'] = array($oIssue->get('assignee_name'), $logged_info->nick_name);
                            $change_args->assignee_srl = $logged_info->member_srl;
                            $change_args->assignee_name = $logged_info->nick_name;

                            $change_args->status = 'assign';
                            $history['status'] = array($oIssue->getStatus(), $status_lang[$change_args->status]);
                            $change_args->status = $change_args->status;
                        break;
                }

                if($change_args!==null) {

                    $change_args->target_srl = $target_srl;
                    $output = executeQueryArray('issuetracker.updateIssue', $change_args);
                    if(!$output->toBool()) return $output;
                    $args->history = serialize($history);
                }
            }
            $args->issues_history_srl = getNextSequence();
            $args->module_srl = $this->module_srl;

            $output = executeQueryArray('issuetracker.insertHistory', $args);
            if(!$output->toBool()) return $output;

            // 전체 댓글 개수를 구함
            $cnt = $oIssuetrackerModel->getHistoryCount($target_srl);
            $oDocumentController = &getController('document');
            $oDocumentController->updateCommentCount($target_srl, $cnt, $logged_info->member_srl);

            $this->add('document_srl', $target_srl);
            $this->add('mid', $this->module_info->mid);
        }

        function procIssuetrackerVerificationPassword() {
            // 비밀번호와 문서 번호를 받음
            $password = Context::get('password');
            $document_srl = Context::get('document_srl');
            $comment_srl = Context::get('comment_srl');

            $oMemberModel = &getModel('member');

            // comment_srl이 있을 경우 댓글이 대상
            if($comment_srl) {
                // 문서번호에 해당하는 글이 있는지 확인
                $oCommentModel = &getModel('comment');
                $oComment = $oCommentModel->getComment($comment_srl);
                if(!$oComment->isExists()) return new Object(-1, 'msg_invalid_request');

                // 문서의 비밀번호와 입력한 비밀번호의 비교
                if(!$oMemberModel->isValidPassword($oComment->get('password'),$password)) return new Object(-1, 'msg_invalid_password');

                $oComment->setGrant();
            } else {
                // 문서번호에 해당하는 글이 있는지 확인
                $oDocumentModel = &getModel('document');
                $oDocument = $oDocumentModel->getDocument($document_srl);
                if(!$oDocument->isExists()) return new Object(-1, 'msg_invalid_request');

                // 문서의 비밀번호와 입력한 비밀번호의 비교
                if(!$oMemberModel->isValidPassword($oDocument->get('password'),$password)) return new Object(-1, 'msg_invalid_password');

                $oDocument->setGrant();
            }
        }

        function procIssuetrackerDeleteTrackback() {
            $trackback_srl = Context::get('trackback_srl');

            // trackback module의 controller 객체 생성
            $oTrackbackController = &getController('trackback');
            $output = $oTrackbackController->deleteTrackback($trackback_srl, $this->grant->manager);
            if(!$output->toBool()) return $output;

            $this->add('mid', Context::get('mid'));
            $this->add('document_srl', $output->get('document_srl'));
            $this->setMessage('success_deleted');
        }

        function syncChangeset()
        {
            require_once($this->module_path.'classes/svn.class.php');
            $oSvn = new Svn($this->module_info->svn_url, $this->module_info->svn_cmd, $this->module_info->diff_cmd);
            $oModel = &getModel('issuetracker');
            $status = $oSvn->getStatus();
            $latestRevision = $oModel->getLatestRevision($this->module_info->module_srl);

            $oController = &getController('issuetracker');
            if($latestRevision < $status->revision)
            {
                $logs = $oSvn->getLog("/", $latestRevision+1, $status->revision, false, $status->revision-$latestRevision);
                foreach($logs as $log)
                {
                    $obj = null;
                    $obj->revision = $log->revision;
                    $obj->author = $log->author;
                    $obj->date = date("YmdHis", strtotime($log->date)); 
                    $obj->message = trim($log->msg);
                    $obj->module_srl = $this->module_info->module_srl;
                    executeQuery("issuetracker.insertChangeset", $obj);
                }
            }
        }

        function procIssuetrackerSync()
        {
            $this->syncChangeset();
        }

    }
?>