/*************************************************************************
 *
 * Copyright 2009 by bBreak Systems.
 *
 * ExCella Core - ExcelファイルをJavaから利用するための共通基盤
 *
 * $Id: BookController.java 56 2009-05-21 04:13:39Z yuta-takahashi $
 * $Revision: 56 $
 *
 * This file is part of ExCella Core.
 *
 * ExCella Core is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Lesser General Public License version 3
 * only, as published by the Free Software Foundation.
 *
 * ExCella Core is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Lesser General Public License version 3 for more details
 * (a copy is included in the COPYING.LESSER file that accompanied this code).
 *
 * You should have received a copy of the GNU Lesser General Public License
 * version 3 along with ExCella Core.  If not, see
 * <http://www.gnu.org/licenses/lgpl-3.0-standalone.html>
 * for a copy of the LGPLv3 License.
 *
 ************************************************************************/
package org.bbreak.excella.core;

import java.io.FileInputStream;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
import org.apache.poi.poifs.filesystem.POIFSFileSystem;
import org.apache.poi.ss.usermodel.Sheet;
import org.apache.poi.ss.usermodel.Workbook;
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
import org.bbreak.excella.core.exception.ExportException;
import org.bbreak.excella.core.exception.ParseException;
import org.bbreak.excella.core.exporter.book.BookExporter;
import org.bbreak.excella.core.exporter.sheet.SheetExporter;
import org.bbreak.excella.core.handler.ParseErrorHandler;
import org.bbreak.excella.core.listener.SheetParseListener;
import org.bbreak.excella.core.tag.TagParser;

/**
 * ワークブックの解析を行うクラス
 * 
 * @since 1.0
 */
public class BookController {

    /** ログ */
    private static Log log = LogFactory.getLog( BookController.class);

    /** Excel2007のファイル末尾 */
    public static final String XSSF_SUFFIX = ".xlsx";

    /** Excel2003以前のファイル末尾 */
    public static final String HSSF_SUFFIX = ".xls";

    /** コメントのプレフィックス */
    public static final String COMMENT_PREFIX = "-";

    /** 処理対象のブック */
    private Workbook workbook;

    /** シート名の一覧 */
    private List<String> sheetNames = new ArrayList<String>();

    /** パーサーのリスト */
    private List<SheetTagParserInfo> tagParers = new ArrayList<SheetTagParserInfo>();

    /** シート解析イベント処理リスナ */
    private List<SheetListenerInfo> sheetListeners = new ArrayList<SheetListenerInfo>();

    /** ブック解析結果出力クラス */
    private List<BookExporter> bookExporters = new ArrayList<BookExporter>();

    /** シート解析結果出力クラス */
    private List<SheetExporterInfo> sheetExporters = new ArrayList<SheetExporterInfo>();

    /** エラーハンドリングクラス */
    private ParseErrorHandler errorHandler = null;

    /** ブックデータ */
    private BookData bookData = new BookData();

    /**
     * コンストラクタ<BR>
     * ファイルの形式を判定してWorkbookを生成する
     * 
     * @param filepath ファイルパス
     * @throws IOException ファイルの読み込みに失敗した場合
     */
    public BookController( String filepath) throws IOException {
        if ( log.isInfoEnabled()) {
            log.info( filepath + "の読み込みを開始します");
        }
        if ( filepath.endsWith( XSSF_SUFFIX)) {
            // XSSF形式
            workbook = new XSSFWorkbook( filepath);
        } else {
            // HSSF形式
            FileInputStream stream = new FileInputStream( filepath);
            POIFSFileSystem fs = new POIFSFileSystem( stream);
            workbook = new HSSFWorkbook( fs);
            stream.close();
        }

        // シート名を解析
        int numOfSheets = workbook.getNumberOfSheets();
        for ( int sheetCnt = 0; sheetCnt < numOfSheets; sheetCnt++) {
            String sheetName = workbook.getSheetName( sheetCnt);
            sheetNames.add( sheetName);
        }
    }

    /**
     * コンストラクタ
     * 
     * @param workbook 処理対象のブック
     */
    public BookController( Workbook workbook) {
        this.workbook = workbook;
        // シート名を解析
        int numOfSheets = workbook.getNumberOfSheets();
        for ( int sheetCnt = 0; sheetCnt < numOfSheets; sheetCnt++) {
            String sheetName = workbook.getSheetName( sheetCnt);
            sheetNames.add( sheetName);
        }
    }

    /**
     * ブックに含まれる全シート(コメントシートを除く)の解析の実行
     * 
     * @throws ParseException パースに失敗した場合
     * @throws IOException エラーファイルの書き込みに失敗した場合
     */
    public void parseBook() throws ParseException, ExportException {
        parseBook( null);
    }

    /**
     * ブックに含まれる全シート(コメントシートを除く)の解析の実行
     * 
     * @param object BookControllerのparseBook(), parseSheet()メソッド、 
     *                SheetParserのparseSheetメソッドで引数を渡した場合に
     *                TagParserまで引き継がれる処理データ
     * @throws ParseException パースに失敗した場合
     * @throws ExportException 出力処理に失敗した場合
     */
    public void parseBook( Object data) throws ParseException, ExportException {
        bookData.clear();
        for ( String sheetName : sheetNames) {
            if ( sheetName.startsWith( COMMENT_PREFIX)) {
                continue;
            }
            // 解析の実行
            SheetData sheetData = parseSheet( sheetName, data);
            // 結果の追加
            bookData.putSheetData( sheetName, sheetData);
        }

        // 出力処理の実行
        for ( BookExporter exporter : bookExporters) {
            if ( exporter != null) {
                exporter.setup();
                try {
                    exporter.export( workbook, bookData);
                } finally {
                    exporter.tearDown();
                }
            }
        }
    }

    /**
     * 現時点での解析データの取得
     * 
     * @return 現時点での解析データ
     */
    public BookData getBookData() {
        return bookData;
    }

    /**
     * 現時点でのWorkbookの取得
     * 
     * @return 現時点でのWorkbook
     */
    public Workbook getBook() {
        return workbook;
    }

    /**
     * シートデータの解析
     * 
     * @param sheetName 解析対象のシート名
     * @return シートの解析結果
     * @throws ParseException パースに失敗した場合
     * @throws ExportException エクスポート処理エラー
     */
    public SheetData parseSheet( String sheetName) throws ParseException, ExportException {
        return parseSheet( sheetName, null);
    }

    /**
     * シートデータの解析
     * 
     * @param sheetName 解析対象のシート名
     * @param object BookControllerのparseBook(), parseSheet()メソッド、 
     *                SheetParserのparseSheetメソッドで引数を渡した場合に
     *                TagParserまで引き継がれる処理データ
     * @return シートの解析結果
     * @throws ParseException パース処理エラー
     * @throws ExportException エクスポート処理エラー
     */
    public SheetData parseSheet( String sheetName, Object data) throws ParseException, ExportException {
        Sheet sheet = workbook.getSheet( sheetName);

        SheetData sheetData = null;
        try {
            SheetParser sheetParser = new SheetParser();

            if ( log.isInfoEnabled()) {
                log.info( "シート[" + sheetName + "]の処理を開始します");
            }

            // タグパーサの追加
            for ( SheetTagParserInfo parserInfo : tagParers) {
                String targetSheetName = parserInfo.getSheetName();
                if ( targetSheetName == null || targetSheetName.equals( sheetName)) {
                    sheetParser.addTagParser( parserInfo.getParser());
                }
            }

            // シート処理前イベントの通知
            for ( SheetListenerInfo lisetnerInfo : sheetListeners) {
                String targetSheetName = lisetnerInfo.getSheetName();
                if ( targetSheetName == null || targetSheetName.equals( sheetName)) {
                    lisetnerInfo.getListener().preParse( sheet, sheetParser);
                }
            }

            // シート解析処理
            sheetData = sheetParser.parseSheet( sheet, data);

            // シート処理後イベントの通知
            for ( SheetListenerInfo lisetnerInfo : sheetListeners) {
                String targetSheetName = lisetnerInfo.getSheetName();
                if ( targetSheetName == null || targetSheetName.equals( sheetName)) {
                    lisetnerInfo.getListener().postParse( sheet, sheetParser, sheetData);
                }
            }
        } catch ( ParseException ex) {
            if ( log.isWarnEnabled()) {
                log.warn( sheetName + "処理中に例外が発生しました", ex);
            }

            // エラーハンドラーへの通知
            if ( errorHandler != null) {
                errorHandler.notifyException( workbook, sheet, ex);
            }
            throw ex;
        }

        // 出力処理の実行
        for ( SheetExporterInfo exporterInfo : sheetExporters) {
            String targetSheetName = exporterInfo.getSheetName();
            if ( targetSheetName == null || targetSheetName.equals( sheetName)) {
                SheetExporter exporter = exporterInfo.getExporter();
                exporter.setup();
                try {
                    exporter.export( sheet, sheetData);
                } finally {
                    exporter.tearDown();
                }
            }
        }
        return sheetData;
    }

    /**
     * ブックに含まれるシート名の一覧取得(コメントシート含む)
     * 
     * @return
     */
    public List<String> getSheetNames() {
        return sheetNames;
    }

    /**
     * タグパーサの追加
     * 
     * @param parser 追加するタグパーサ
     */
    public void addTagParser( TagParser<?> parser) {
        tagParers.add( new SheetTagParserInfo( parser));
    }

    /**
     * 対象シート指定でのタグパーサの追加
     * 
     * @param sheetName 対象シート名
     * @param parser 追加するタグパーサ
     */
    public void addTagParser( String sheetName, TagParser<?> parser) {
        tagParers.add( new SheetTagParserInfo( sheetName, parser));
    }

    /**
     * シート処理リスナの追加
     * 
     * @param listener 追加するリスナ
     */
    public void addSheetParseListener( SheetParseListener listener) {
        sheetListeners.add( new SheetListenerInfo( listener));
    }

    /**
     * シート処理リスナの追加
     * 
     * @param sheetName 対象シート名
     * @param listener 追加するリスナ
     */
    public void addSheetParseListener( String sheetName, SheetParseListener listener) {
        sheetListeners.add( new SheetListenerInfo( sheetName, listener));
    }

    /**
     * シート解析結果出力クラスの追加
     * 
     * @param exporter 追加する出力クラス
     */
    public void addSheetExporter( SheetExporter exporter) {
        sheetExporters.add( new SheetExporterInfo( exporter));
    }

    /**
     * シート解析結果出力クラスの追加
     * 
     * @param sheetName 対象シート名
     * @param exporter 追加する出力クラス
     */
    public void addSheetExporter( String sheetName, SheetExporter exporter) {
        sheetExporters.add( new SheetExporterInfo( sheetName, exporter));
    }

    /**
     * エラーハンドラの取得
     * 
     * @return エラーハンドラ
     */
    public ParseErrorHandler getErrorHandler() {
        return errorHandler;
    }

    /**
     * エラーハンドラの設定
     * 
     * @return エラーハンドラ
     */
    public void setErrorHandler( ParseErrorHandler errorHandler) {
        this.errorHandler = errorHandler;
    }

    /**
     * 出力処理クラスの取得
     * 
     * @return 出力処理クラス
     */
    public List<BookExporter> getExporter() {
        return bookExporters;
    }

    /**
     * 出力処理クラスの追加
     * 
     * @param exporter 出力処理クラス
     */
    public void addBookExporter( BookExporter exporter) {
        bookExporters.add( exporter);
    }

    /**
     * シートごとのパーサ情報を保持するクラス
     * 
     * @since 1.0
     */
    private class SheetTagParserInfo {

        /** シート名 */
        private String sheetName = null;

        /** パーサ */
        private TagParser<?> parser = null;

        /**
         * コンストラクタ
         * 
         * @param sheetName シート名
         * @param parser パーサ
         */
        public SheetTagParserInfo( String sheetName, TagParser<?> parser) {
            this.sheetName = sheetName;
            this.parser = parser;
        }

        /**
         * コンストラクタ
         * 
         * @param parser パーサ
         */
        public SheetTagParserInfo( TagParser<?> parser) {
            this.parser = parser;
        }

        public String getSheetName() {
            return sheetName;
        }

        public TagParser<?> getParser() {
            return parser;
        }
    }

    /**
     * シートごとのリスナ情報を保持するクラス
     * 
     * @since 1.0
     */
    private class SheetListenerInfo {

        /** シート名 */
        private String sheetName = null;

        /** リスナ */
        private SheetParseListener listener = null;

        /**
         * コンストラクタ
         * 
         * @param sheetName シート名
         * @param listener リスナ
         */
        public SheetListenerInfo( String sheetName, SheetParseListener listener) {
            this.sheetName = sheetName;
            this.listener = listener;
        }

        /**
         * コンストラクタ
         * 
         * @param listener リスナ
         */
        public SheetListenerInfo( SheetParseListener listener) {
            this.listener = listener;
        }

        public String getSheetName() {
            return sheetName;
        }

        public SheetParseListener getListener() {
            return listener;
        }
    }

    /**
     * シートごとのExporter情報を保持するクラス
     * 
     * @since 1.0
     */
    private class SheetExporterInfo {

        /** シート名 */
        private String sheetName = null;

        /** エクスポータ */
        private SheetExporter exporter = null;

        /**
         * コンストラクタ
         * 
         * @param sheetName シート名
         * @param exporter エクスポータ
         */
        public SheetExporterInfo( String sheetName, SheetExporter exporter) {
            this.sheetName = sheetName;
            this.exporter = exporter;
        }

        /**
         * コンストラクタ
         * 
         * @param exporter エクスポータ
         */
        public SheetExporterInfo( SheetExporter exporter) {
            this.exporter = exporter;
        }

        public String getSheetName() {
            return sheetName;
        }

        public SheetExporter getExporter() {
            return exporter;
        }
    }
}
