/*********************************************************************
*  All Rights reserved,Copyright (c) K-Opticom
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatDKTanaMoveShkaCmpFileIns
*	ソースファイル名	：JBSbatDKTanaMoveShkaCmpFileIns.java
*	作成者				：富士通　
*	作成日				：2011年08月31日
*＜機能概要＞
*　棚移動出荷完了ファイル登録部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*	v1.00.00	2011/08/31   富士通		新規作成
*	v10.00.00	2014/10/08   FJ）舩橋	ANK-2029-00-00
*********************************************************************/
package eo.business.service;

import static eo.common.constant.JDKStrConst.PATH_DLMT_UNIX;
import static eo.common.constant.JDKStrConst.PATH_DLMT_WIN;

import java.io.BufferedWriter;
import java.io.File;
import java.io.FileOutputStream;
import java.io.FilenameFilter;
import java.io.OutputStreamWriter;
import java.util.ArrayList;
import java.util.List;

import eo.business.common.JBSbatBusinessService;
import eo.business.common.JCCBatCommon;
import eo.common.constant.JDKStrConst;
import eo.common.constant.JPCBatchMessageConstant;
import eo.common.util.JDKCommonUtil;
import eo.framework.application.JBSbatBusinessException;
import eo.framework.db.JBSbatSQLAccess;
import eo.framework.file.JBSbatInputFileUtil;
import eo.framework.item.JBSbatCommonDBInterface;
import eo.framework.item.JBSbatCommonItem;
import eo.framework.item.JBSbatOutputItem;
import eo.framework.util.JBSbatAplConst;
import eo.framework.util.JBSbatDateUtil;

// ANK-2029-00-00 ADD START
import eo.framework.util.JBSbatBusinessFileUtil;
import eo.framework.file.JBSbatOutputFileUtil;
import eo.framework.file.JBSbatDefFileUtil;
// ANK-2029-00-00 ADD END

/**
* (クラスの機能概要) <p>
*<BR>
* @author 富士通
*/
public class JBSbatDKTanaMoveShkaCmpFileIns extends JBSbatBusinessService
{
	/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
	/** テーブル(ダウンロードファイル管理)*/
	private static final String D_TBL_NAME_ZM_T_DL_FILE_KANRI = "ZM_T_DL_FILE_KANRI";

	/** SQL定義キー(DK_INSERT_002)*/
	private static final String ZM_T_DL_FILE_KANRI_DK_INSERT_002 = "DK_INSERT_002";

	/** テーブルアクセスクラス(ダウンロードファイル管理)*/
	private JBSbatSQLAccess db_ZM_T_DL_FILE_KANRI = null;
	/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/

	/** 処理管理番号 */
	private static final String TRN_KANRI_NO = "000000000033";

	// ANK-2029-00-00 ADD START
	/** ファイル定義 */
	private static final String PARAM_OTD = "OTD";

	/** ファイル出力内容リスト */
	private ArrayList<String> OutValueList = null;
	// ANK-2029-00-00 ADD END

	/**
	 * 初期処理
	 * @param JBSbatCommonItem commonItem　バッチ共通パラメータ電文
	 * @throws Exception
	 */
	public void initial(JBSbatCommonItem commonItem) throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
		// 共通パラメータを設定します
		super.setCommonInfo(commonItem);

		// DBアクセスクラスを生成します
		db_ZM_T_DL_FILE_KANRI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_ZM_T_DL_FILE_KANRI);
		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
	/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 主処理
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		
		// パラメータの取得（Freeパラメータ）
		// 出荷完了情報ファイルが格納されているフォルダの環境変数名を取得する
		String[] freeParam = commonItem.getFreeItem().split(JDKStrConst.FREE_DLMT);

		// 1.2.2.1 処理開始判定
		//ファイルの存在確認
		File file = new File(freeParam[0]);
		if (!file.exists())
		{
			super.commonItem.getLogPrint().printDebugLog("棚移動出荷完了ファイルなし");
			return null;
		}
		File flgFile = new File(freeParam[0].replaceAll(".csv", ".flg"));
		if (!flgFile.exists())
		{
			super.commonItem.getLogPrint().printDebugLog("棚移動出荷完了フラグファイルなし");
			return null;
		}

		// 棚移動出荷完了ファイルを分割
		List<File> splitFileList = splitFile(file);

		for (File splitFile : splitFileList)
		{
			// 1.2.2.2 電子ファイル管理データの登録を行う
			String[] resultKey = null;		// 電子ファイル管理テーブルに登録された場合に返却されるPKEY
			try
			{
				resultKey = JCCBatCommon.createDenshiFile(commonItem, null, splitFile.getPath(), JBSbatDateUtil.adjustMonth(commonItem.getOpeDate(), 3));
			}
			catch (Exception ex)
			{
				// 電子ファイル管理テーブル登録失敗
				commonItem.getConnection().rollback();
				commonItem.getLogPrint().printBusinessErrorLog(JPCBatchMessageConstant.EDKB0070CE,
						new String[] {"電子ファイル管理", "棚移動出荷完了情報受信ファイル名＝" + splitFile.getPath()});
				throw ex;
			}

			// 1.2.2.3 電子ファイル管理テーブルに正常登録された場合ダウンロードファイル管理の登録を行う
			try
			{
				String[] insertData = new String[9];
				insertData[0] = TRN_KANRI_NO;
				insertData[1] = splitFile.getName();
				insertData[2] = JCCBatCommon.getSysDateTimeStamp();
				insertData[3] = JCCBatCommon.getSysDateTimeStamp();
				insertData[4] = commonItem.getBatchUserId();
				insertData[5] = JCCBatCommon.getSysDateTimeStamp();
				insertData[6] = commonItem.getBatchUserId();
				insertData[7] = resultKey[0];
				insertData[8] = resultKey[1];
				
				executeZM_T_DL_FILE_KANRI_DK_INSERT_002(insertData);

				// ANK-2029-00-00 ADD START
				// ファイル出力内容リスト
				OutValueList = new ArrayList<String>();
				OutValueList.add(resultKey[0]);
				// ANK-2029-00-00 ADD END
			}
			catch (Exception ex)
			{
				// ダウンロードファイル管理テーブル登録失敗
				String buff = TRN_KANRI_NO + "," + resultKey[0] + ",'棚移動出荷完了ファイル登録エラー'";
				commonItem.getConnection().rollback();
				commonItem.getLogPrint().printBusinessErrorLog(JPCBatchMessageConstant.EDKB0070CE,
						new String[] {"ダウンロードファイル管理", buff});
				throw ex;
			}
		}

		super.commonItem.getLogPrint().printDebugLog("棚移動出荷完了ファイル登録処理終了");

		// 1.2.2.4 バックアップ処理
		doBackup(file);
		doBackup(flgFile);
		for (File splitFile : splitFileList)
		{
			doBackup(splitFile);
		}

		super.commonItem.getLogPrint().printDebugLog("バックアップ処理終了");

		// 後処理
		super.commit();

		// ANK-2029-00-00 ADD START
		if (OutValueList != null) {
			this.outputFile(freeParam[1], freeParam[2], freeParam[3]);
			super.commonItem.getLogPrint().printDebugLog("棚移動出荷完了ファイル：" + freeParam[1] + freeParam[2]);
		}
		// ANK-2029-00-00 ADD END

		return null;
	/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * 業務サービス終了処理
	 * @throws Exception
	 */
	public void terminal() throws Exception
	{
	/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
		// DBアクセスクラスをクローズします
		db_ZM_T_DL_FILE_KANRI.close();
		/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
	/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
	}

	/**
	 * SQLKEY(DK_INSERT_002)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数でバイント変数を設定します。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	処理管理番号
	 *		 	ファイル名
	 *		 	ファイル登録年月日時分秒
	 *		 	登録年月日時分秒
	 *		 	登録オペレータアカウント
	 *		 	更新年月日時分秒
	 *		 	更新オペレータアカウント
	 *		 	電子ファイル管理番号
	 *		 	ファイルサイズ
	 * </pre>
	 * <p>
	 * @param param バイント変数の値配列。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeZM_T_DL_FILE_KANRI_DK_INSERT_002(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());
		paramList.setValue(param[1].toString());
		paramList.setValue(param[2].toString());
		paramList.setValue(param[3].toString());
		paramList.setValue(param[4].toString());
		paramList.setValue(param[5].toString());
		paramList.setValue(param[6].toString());
		paramList.setValue(param[7].toString());
		paramList.setValue(param[8].toString());

		// DBアクセスを実行します
		db_ZM_T_DL_FILE_KANRI.executeBySqlDefine(paramList, ZM_T_DL_FILE_KANRI_DK_INSERT_002);
	}

	/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/

	/**
	 * 指定されたファイルを分割する。
	 * 
	 * @param orgFile 分割元ファイル
	 * @return 分割されたファイルリスト
	 * @throws Exception
	 */
	private List<File> splitFile(File orgFile) throws Exception
	{
		// 分割されたファイルリスト
		List<File> splitFileList = new ArrayList<File>();

		// 分割されたファイルが既存に存在する場合は削除
		deleteSplitFile(orgFile);

		// 分割元ファイルユーティリティ
		JBSbatInputFileUtil orgFileUtil = new JBSbatInputFileUtil(orgFile.getPath());
		// 文字コードを設定
		orgFileUtil.setEncode(JDKStrConst.ENCODE_SJIS2);
		// 分割元ファイルの入力ストリームを生成
		orgFileUtil.createReader();

		// 分割先ファイルの出力ストリーム
		BufferedWriter splitFileWriter = null;
		// 分割先ファイルのインデックス
		int fileIndex = 1;
		// 分割先ファイル名
		String newFilename = null;
		// 分割判定フラグ
		boolean split = true;
		// 分割元ファイルの内容（1行単位）
		String line = null;

		while (orgFileUtil.ready())
		{
			// 分割先ファイルを作成
			if (split)
			{
				// 分割先ファイル名を設定
				newFilename = orgFile.getPath().replaceAll(".csv", "") + String.format("_%03d", fileIndex++) + ".csv";
				// 新規分割先ファイルを作成
				splitFileWriter = new BufferedWriter(new OutputStreamWriter(
						new FileOutputStream(newFilename, true), JDKStrConst.CHAR_SET_WIN31J));
				splitFileList.add(new File(newFilename));
				split = false;
				super.commonItem.getLogPrint().printDebugLog("分割ファイル作成：" + newFilename);
			}

			// 棚移動出荷完了ファイルの読込み（1行単位）
			line = orgFileUtil.readLine();
			// レコード種別が"78"（トレーラー）の場合はファイルを分割
			int index = line.indexOf(JDKStrConst.COMMA);
			if (line.substring(0, index).contains(JDKStrConst.RECORD_SBT_DKIFE00402_TRAILER))
			{
				// トレーラー部の場合
				// 分割先ファイルに読込んだ内容を書込み（1行）
				splitFileWriter.write(line);
				splitFileWriter.flush();

				// 分割先ファイルの作成完了
				splitFileWriter.close();
				split = true;
			}
			else
			{
				// データ部の場合
				// 分割先ファイルに読込んだ内容を書込み（1行）
				splitFileWriter.write(line);
				splitFileWriter.write(JDKStrConst.LINE_SEPARATOR);
			}
		}

		// 分割元／分割先ファイルストリームをクローズ
		orgFileUtil.close();
		if (splitFileWriter != null && !split)
		{
			splitFileWriter.flush();
			splitFileWriter.close();
		}

		super.commonItem.getLogPrint().printDebugLog("棚移動出荷完了ファイル分割処理終了");

		return splitFileList;
	}

	/**
	 * 指定されたファイルで分割されたファイルを削除する。
	 * 
	 * @param orgFile 分割元ファイル
	 * @throws Exception
	 */
	private void deleteSplitFile(final File orgFile) throws Exception
	{
		// ディレクトリ
		File orgDir = new File(orgFile.getParent());
		// 削除するファイルを取得
		File[] delFiles = orgDir.listFiles(new FilenameFilter()
		{
			/* (非 Javadoc)
			 * @see java.io.FilenameFilter#accept(java.io.File, java.lang.String)
			 */
			@Override
			public boolean accept(File dir, String name)
			{
				if (name.endsWith(".flg"))
				{
					return false;
				}
				
				String basename = name.replaceAll(".csv", "");
				String orgFileBasename = orgFile.getName().replaceAll(".csv", "");
				// 指定されたファイルを元に分割されたファイルの場合
				if (!basename.equals(orgFileBasename)
						&& basename.startsWith(orgFileBasename))
				{
					return true;
				}
				return false;
			}
		});

		// ファイルを削除
		for (File delFile : delFiles)
		{
			delFile.delete();
			super.commonItem.getLogPrint().printDebugLog("分割ファイル削除：" + delFile.getPath());
		}
	}

	/**
	 * ファイルを移動させる
	 * 
	 * @param srcFile 移動元ファイル
	 * @throws Exception
	 */
	private void doBackup(File srcFile) throws Exception
	{
		boolean errorFlg = false;
		String distFile = null;

		try
		{
			String path = JBSbatAplConst.getAplConstValue(JDKStrConst.ENV_GAIBU_RECEIVE_DIR);
			path = path + "/DKIFE004/bk";
			// ディレクトリが存在しない場合作成する
			if (!new File(path).isDirectory())
			{
				new File(path).mkdir();
			}
			distFile = this.rnktPath(path, srcFile.getName());
			errorFlg = !srcFile.renameTo(new File(distFile));

			super.commonItem.getLogPrint().printDebugLog("バックアップファイル：" + srcFile.getPath());
		}
		catch (Exception ex)
		{
			if (JDKCommonUtil.isNull(distFile))
			{
				distFile = "null/" + srcFile.getName();
			}
			commonItem.getConnection().rollback();
			super.logPrint.printDebugLog("ファイルの書き込みに失敗しました。;" + "ファイル名＝" + distFile);
			commonItem.getLogPrint().printBusinessErrorLog(JPCBatchMessageConstant.EDKB0050CE,
					new String[] {distFile});
			throw ex;
		}

		if (errorFlg)
		{
			if (JDKCommonUtil.isNull(distFile))
			{
				distFile = "null/" + srcFile.getName();
			}
			commonItem.getConnection().rollback();
			super.logPrint.printDebugLog("ファイルの書き込みに失敗しました。;" + "ファイル名＝" + distFile);
			throw new JBSbatBusinessException(JPCBatchMessageConstant.EDKB0050CE, new String[] {distFile});
		}
	}

	/**
	 * パス文字列の連結
	 * 連結するパス文字列にパス区切り文字の設定を制御する。
	 * @param path1 パス文字列
	 * @param path2 パス文字列
	 * @return 連結したパス文字列
	 */
	private String rnktPath(String path1, String path2)
	{
		String pathDlmt = PATH_DLMT_UNIX;
		StringBuffer buff = new StringBuffer();
		
		if (path1.indexOf(PATH_DLMT_WIN) > -1 || path2.indexOf(PATH_DLMT_WIN) > -1)
		{
			pathDlmt = PATH_DLMT_WIN;
		}
		if (!path1.endsWith(pathDlmt))
		{
			return buff.append(path1).append(pathDlmt).append(path2).toString();
		}
		return buff.append(path1).append(path2).toString();
	}

	// ANK-2029-00-00 ADD START
	/**
	 * ファイル出力
	 * <BR>
	 * @param outDir 出力ディレクトリ
	 * @param outFileName 出力ファイル名
	 * @param defFileName 定義ファイル名
	 * @throws Exception スローされる例外
	 */
	private void outputFile(String outDir, String outFileName, String defFileName) throws Exception
	{
		String outFilePath = outDir + outFileName;
		JBSbatOutputFileUtil dataFile = new JBSbatOutputFileUtil(outFilePath);

		String outFileDefPath = JBSbatAplConst.getAplConstValue(PARAM_OTD) + defFileName;
		JBSbatDefFileUtil dataFileDef = new JBSbatDefFileUtil(outFileDefPath, dataFile);

		String encode = dataFile.getEncode();

		// ファイルの生成
		JBSbatBusinessFileUtil fileUtil = JCCBatCommon.createBusinessFileUtil(outFilePath, encode, "", dataFileDef.getDelimiter());

		// データ数分繰り返し
		for(int i = 0; i < OutValueList.size(); i++)
		{
			// ファイルに書き込み
			JCCBatCommon.printBusinessFileUtil(fileUtil, OutValueList.get(i));
		}

		// ファイルを閉じる
		JCCBatCommon.closeBusinessFileUtil(fileUtil);
	}
	// ANK-2029-00-00 ADD END
}