/*********************************************************************
*  All Rights reserved,Copyright (c) Fujitsu ,2016					 *
**********************************************************************
*＜プログラム内容＞
*	システム名			：eo顧客基幹システム
*	モジュール名		：JBSbatCRQueAuthIktAdd
*	ソースファイル名	：JBSbatCRQueAuthIktAdd.java
*	作成者				：富士通　
*	作成日				：2016年08月17日
*＜機能概要＞
*　キュー権限一括登録処理部品です。
*＜修正履歴＞
*	バージョン	修正日		修正者		修正内容
*   v26.00.00   2016/08/01	FJ) 舘山    ANK-2875-00-00_（客A)アカウント追加時のキュー権限自動付与
*********************************************************************/
package eo.business.service;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;

import eo.business.common.JBSbatBusinessService;
import eo.business.common.JCCBatCommon;
import eo.business.common.JCCbatShoriIraiUtil;
import eo.business.common.JCRBatCommon;
import eo.business.common.JKKBatCommon;
import eo.business.common.JKKBatConst;
import eo.business.common.JKKBatOutputUtil;
import eo.business.util.file.JBSbatCRIFM003;
import eo.business.util.file.JBSbatCRIFM004;
import eo.business.util.table.JBSbatCC_T_DLYD_TRN_REQ;
import eo.business.util.table.JBSbatCC_T_EFILE_KANRI;
import eo.business.util.table.JBSbatZM_M_CD_NM_KANRI;
import eo.business.util.table.JBSbatZM_M_USER;
import eo.common.constant.JPCBatchMessageConstant;
import eo.common.util.JCCFileUtil;
import eo.common.util.JKKStringUtil;
import eo.framework.application.JBSbatBusinessException;
import eo.framework.db.JBSbatSQLAccess;
import eo.framework.file.JBSbatDefFileUtil;
import eo.framework.file.JBSbatInputFileUtil;
import eo.framework.item.JBSbatCommonDBInterface;
import eo.framework.item.JBSbatCommonItem;
import eo.framework.item.JBSbatOutputItem;
import eo.framework.item.JBSbatServiceInterfaceMap;
import eo.framework.util.JBSbatAplConst;
import eo.framework.util.JBSbatCheckUtil;
import eo.framework.util.JBSbatDateUtil;

/**
* (クラスの機能概要) <p>
*<BR>
* @author 富士通
*/
public class JBSbatCRQueAuthIktAdd  extends JBSbatBusinessService
{

	/** テーブル(電子ファイル管理)*/
	private static final String D_TBL_NAME_CC_T_EFILE_KANRI = "CC_T_EFILE_KANRI";
	/** テーブル(キューBOX)*/
	private static final String D_TBL_NAME_CR_T_QUE_BOX = "CR_T_QUE_BOX";
	/** テーブル(キューメンバー)*/
	private static final String D_TBL_NAME_CR_M_QUE_MEMBER = "CR_M_QUE_MEMBER";
	/** テーブル(ユーザー)*/
	private static final String D_TBL_NAME_ZM_M_USER = "ZM_M_USER";
	/** テーブル(コード名称管理)*/
	private static final String D_TBL_NAME_ZM_M_CD_NM_KANRI = "ZM_M_CD_NM_KANRI";
	/** テーブル(データ一括登録管理)*/
	private static final String D_TBL_NAME_ZM_T_DATAIKTTRK_KNRI = "ZM_T_DATAIKTTRK_KNRI";
	/** テーブル(ダウンロードファイル管理)*/
	private static final String D_TBL_NAME_ZM_T_DL_FILE_KANRI = "ZM_T_DL_FILE_KANRI";

	/** SQL定義キー(KK_SELECT_001)*/
	private static final String CC_T_EFILE_KANRI_KK_SELECT_001 = "KK_SELECT_001";
	/** SQL定義キー(KK_SELECT_007)*/
	private static final String ZM_M_CD_NM_KANRI_KK_SELECT_004 = "KK_SELECT_004";
	/** SQL定義キー(KK_SELECT_002)*/
	private static final String ZM_T_DATAIKTTRK_KNRI_KK_SELECT_002= "KK_SELECT_002";
	/** SQL定義キー(CR_SELECT_002)*/
	private static final String ZM_M_USER_CR_SELECT_002 = "CR_SELECT_002";
	/** SQL定義キー(CR_SELECT_009)*/
	private static final String CR_T_QUE_BOX_CR_SELECT_009 = "CR_SELECT_009";
	/** SQL定義キー(CR_SELECT_001)*/
	private static final String CR_M_QUE_MEMBER_CR_SELECT_001 = "CR_SELECT_001";

	/** テーブルアクセスクラス(電子ファイル管理)*/
	private JBSbatSQLAccess db_CC_T_EFILE_KANRI = null;
	/** テーブルアクセスクラス(キューBOX)*/
	private JBSbatSQLAccess db_CR_T_QUE_BOX = null;
	/** テーブルアクセスクラス(キューメンバー)*/
	private JBSbatSQLAccess db_CR_M_QUE_MEMBER = null;
	/** テーブルアクセスクラス(ユーザー)*/
	private JBSbatSQLAccess db_ZM_M_USER = null;
	/** テーブルアクセスクラス(コード名称管理)*/
	private JBSbatSQLAccess db_ZM_M_CD_NM_KANRI = null;
	/** テーブルアクセスクラス(ディレイド処理依頼)*/
	private JBSbatSQLAccess db_ZM_T_DATAIKTTRK_KNRI = null;
	/** テーブルアクセスクラス(ダウンロードファイル管理)*/
	private JBSbatSQLAccess db_ZM_T_DL_FILE_KANRI = null;

	/** 追加／削除フラグの処理モード（追加）*/
	private static final String MODE_ADD = "1";
	/** 追加／削除フラグの処理モード（削除）*/
	private static final String MODE_DEL = "0";
	
	/** 処理結果（ＯＫ）*/
	private static final String RST_OK = "0";
	/** 処理結果（ＮＧ）*/
	private static final String RST_NG = "1";

	/** メッセージ出力用のマップ */
	private HashMap<String, String> errCodeMap = null;
	/** 処理結果出力文字のマップ*/
	private HashMap<String, String> resultCodeMap = null;
	
	/** エラーメッセージ取得用コード名称 */
	private static final String CD_NM_KANRI_QUE_IKT_ADD_ERR_CD = "CD01697";
	/** 処理結果取得用コード名称 */
	private static final String CD_NM_KANRI_QUE_IKT_ADD_RSLT_CD = "CD01698";

	/** エラーコード（入力ファイルのレイアウト、またはファイル形式が不正です。） */
	private static final String ERR_CD_E010 = "E010";
	/** エラーコード（従業員番号の設定内容が不正です。） */
	private static final String ERR_CD_E020 = "E020";
	/** エラーコード（キューBOX番号の設定内容が不正です。） */
	private static final String ERR_CD_E030 = "E030";
	/** エラーコード（追加／削除フラグの設定内容が不正です。） */
	private static final String ERR_CD_E040 = "E040";
	/** エラーコード（従業員が存在しません。） */
	private static final String ERR_CD_E100 = "E100";
	/** エラーコード（キューBOX番号が存在しません。） */
	private static final String ERR_CD_E110 = "E110";
	/** エラーコード（権限が既に割り当てられています。） */
	private static final String ERR_CD_E120 = "E120";
	/** エラーコード（権限が付与されていません。） */
	private static final String ERR_CD_E130 = "E130";
	/** エラーコード（キューBOX内の最後のメンバーは削除できません。） */
	private static final String ERR_CD_E140 = "E140";
	/** エラーコード（ＤＢエラー。） */
	private static final String ERR_CD_E200 = "E200";
	/** 正常なし */
	private static final String NO_ERROR = "";
	
	/**
	 * 初期処理
	 * @param JBSbatCommonItem commonItem　バッチ共通パラメータ電文
	 * @throws Exception
	 */
	@Override
	public void initial(JBSbatCommonItem commonItem) throws Exception 
	{
		/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
		// 共通パラメータを設定します
		super.setCommonInfo(commonItem);

		// DBアクセスクラスを生成します
		db_CC_T_EFILE_KANRI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CC_T_EFILE_KANRI);
		db_CR_T_QUE_BOX = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CR_T_QUE_BOX);
		db_CR_M_QUE_MEMBER = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CR_M_QUE_MEMBER);
		db_ZM_M_USER = new JBSbatSQLAccess(commonItem, D_TBL_NAME_ZM_M_USER);
		db_ZM_M_CD_NM_KANRI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_ZM_M_CD_NM_KANRI);
		db_ZM_T_DATAIKTTRK_KNRI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_ZM_T_DATAIKTTRK_KNRI);
		db_ZM_T_DL_FILE_KANRI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_ZM_T_DL_FILE_KANRI);

		/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
		/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
	}
	/**
	 * ディレイド処理依頼でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数でバイント変数を設定します。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	予約適用年月日
	 *		 	サービス契約番号
	 * </pre>
	 * <p>
	 * @param param バイント変数の値配列。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private JBSbatCommonDBInterface executeZM_T_DATAIKTTRK_KNRI_KK_SELECT_002(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());

		// DBアクセスを実行します
		db_ZM_T_DATAIKTTRK_KNRI.selectBySqlDefine(paramList, ZM_T_DATAIKTTRK_KNRI_KK_SELECT_002);
		return db_ZM_T_DATAIKTTRK_KNRI.selectNext();
	}
	
	/**
	 * SQLKEY(KK_SELECT_001)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数でバイント変数を設定します。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	電子ファイル管理番号
	 * </pre>
	 * <p>
	 * @param param バイント変数の値配列。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeCC_T_EFILE_KANRI_KK_SELECT_001(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());

		// DBアクセスを実行します
		db_CC_T_EFILE_KANRI.selectBySqlDefine(paramList, CC_T_EFILE_KANRI_KK_SELECT_001);
	}
	
	/**
	 * 電子ファイル管理スキーマより、電子ファイル管理の情報を取得します。
	 * 
	 * @param eFileNO 		電子ファイル管理番号
	 * @return dbMap		電子ファイル管理の情報
	 * @throws Exception 　業務サービス内で発生した例外全般
	 */
	private JBSbatCommonDBInterface getEfileKanriInfo(String eFileKanriNo) throws Exception
	{
		Object[] param = new Object[1];
		param[0] = eFileKanriNo;
		
		// SQL実行
		executeCC_T_EFILE_KANRI_KK_SELECT_001(param);
		
		// 結果取得
		JBSbatCommonDBInterface dbMap = db_CC_T_EFILE_KANRI.selectNext();
		
		if (dbMap == null)
		{
			// DB未存在エラー
			String[] msgParam = new String[]
			{ JBSbatCC_T_EFILE_KANRI.TABLE_NAME };
			throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0720KW, msgParam);
		}
		return dbMap;
	}
	
	/**
	 * PK(全項目登録)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数で設定項目マップを作ります。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。
	 *		 	ファイル番号				FILE_NO
	 *		 	処理管理番号				TRN_KANRI_NO
	 *		 	電子ファイル管理番号				EFILE_KANRI_NO
	 *		 	ファイル名				FILE_NM
	 *		 	ファイルサイズ				FILE_SIZE
	 *		 	データ件数				DATA_CNT
	 *		 	ファイル登録年月日時分秒				FILE_ADD_DTM
	 *		 	ファイル削除年月日				FILE_DEL_YMD
	 *		 	登録年月日時分秒				ADD_DTM
	 *		 	登録オペレータアカウント				ADD_OPEACNT
	 *		 	更新年月日時分秒				UPD_DTM
	 *		 	更新オペレータアカウント				UPD_OPEACNT
	 *		 	削除年月日時分秒				DEL_DTM
	 *		 	削除オペレータアカウント				DEL_OPEACNT
	 *		 	無効フラグ				MK_FLG
	 * </pre>
	 * <p>
	 * @param setParam 設定項目の値。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private void executeZM_T_DL_FILE_KANRI_PKINSERT(Object[] setParam) throws Exception
	{
		// 設定値のマップを作成します
		JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
		setMap.setValue("FILE_NO", setParam[0]);
		setMap.setValue("TRN_KANRI_NO", setParam[1]);
		setMap.setValue("EFILE_KANRI_NO", setParam[2]);
		setMap.setValue("FILE_NM", setParam[3]);
		setMap.setValue("FILE_SIZE", setParam[4]);
		setMap.setValue("DATA_CNT", setParam[5]);
		setMap.setValue("FILE_ADD_DTM", setParam[6]);
		setMap.setValue("FILE_DEL_YMD", setParam[7]);
		setMap.setValue("ADD_DTM", setParam[8]);
		setMap.setValue("ADD_OPEACNT", setParam[9]);
		setMap.setValue("UPD_DTM", setParam[10]);
		setMap.setValue("UPD_OPEACNT", setParam[11]);
		setMap.setValue("DEL_DTM", setParam[12]);
		setMap.setValue("DEL_OPEACNT", setParam[13]);
		setMap.setValue("MK_FLG", setParam[14]);
	
		// DBアクセスを実行します
		db_ZM_T_DL_FILE_KANRI.insertByPrimaryKeys(setMap);
	}
	
	/**
	 * ダウンロードファイル管理テーブルの登録を行います。
	 * <br>
	 * @param eFileKanriNo 電子ファイル管理番号
	 * @param fileName   ファイル名
	 * @param filePath   ファイルパス
	 * @param rowCnt     データ件数
	 * @throws Exception 
	 */
	private void insertZM_T_DL_FILE_KANRI(String eFileKanriNo, String fileName, String filePath, int rowCnt, String trn_kanri_no) throws Exception
	{
		JBSbatCommonDBInterface eFileInfo = getEfileKanriInfo(eFileKanriNo);
		
		// パラメータ設定
		Object[] prm = new Object[15];
		prm[0] = JKKBatCommon.getFormatedNextSeq(commonItem, "SEQ_FILE_NO", "", 12);
		prm[1] = trn_kanri_no;
		prm[2] = eFileKanriNo;
		prm[3] = fileName;
		prm[4] = JCCFileUtil.getFileSize(filePath);
		prm[5] = String.valueOf(rowCnt);
		prm[6] = eFileInfo.getString(JBSbatCC_T_EFILE_KANRI.ADD_DTM);
		prm[7] = eFileInfo.getString(JBSbatCC_T_EFILE_KANRI.FILE_DEL_YMD);
		prm[8] = JBSbatDateUtil.getSystemDateTimeStamp();
		prm[9] = "SYSTEM";
		prm[10] = JBSbatDateUtil.getSystemDateTimeStamp();
		prm[11] = "SYSTEM";
		prm[12] = null;
		prm[13] = null;
		prm[14] = "0";

		executeZM_T_DL_FILE_KANRI_PKINSERT(prm);
	}
	
	/**
	 * SQLKEY(KK_SELECT_007)でDBアクセスを行います。<br>
	 * <p>
	 * <b>処理フロー</b><br>
	 * <pre>
	 * 1.引数でバイント変数を設定します。<br>
	 *
	 * 2.DBアクセスを実行します。<br>
	 * 
	 * 3.メソッドの呼び出し方です。<br>
	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	コード種別コード
	 *		 	コード適用開始年月日
	 *		 	コード適用終了年月日
	 * </pre>
	 * <p>
	 * @param param バイント変数の値配列。
	 * @throws Exception 業務サービス内で発生した例外全般。
	 */
	private HashMap<String, String> executeZM_M_CD_NM_KANRI_KK_SELECT_004(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());
		paramList.setValue(param[1].toString());
		paramList.setValue(param[2].toString());

		HashMap<String, String> r = new HashMap<String, String>();
		// DBアクセスを実行します
		db_ZM_M_CD_NM_KANRI.selectBySqlDefine(paramList, ZM_M_CD_NM_KANRI_KK_SELECT_004);
		 
		for (JBSbatCommonDBInterface one = db_ZM_M_CD_NM_KANRI.selectNext(); one != null; one=db_ZM_M_CD_NM_KANRI.selectNext())
		{
			r.put( one.getString(JBSbatZM_M_CD_NM_KANRI.CD_DIV),
					one.getString(JBSbatZM_M_CD_NM_KANRI.CD_DIV_NM) );
		}
		return r;
	}
	
	/**
	 * ユーザを取得する
	 * @param param
	 * @return
	 * @throws Exception
	 */
	private JBSbatCommonDBInterface  executeZM_M_USER_CR_SELECT_002(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());
		paramList.setValue(param[1].toString());
		paramList.setValue(param[2].toString());

		// DBアクセスを実行します
		db_ZM_M_USER.selectBySqlDefine(paramList, ZM_M_USER_CR_SELECT_002);
		return db_ZM_M_USER.selectNext();
	}

	/**
	 * キューBOXを検索する
	 * @param param
	 * @return
	 * @throws Exception
	 */
	private JBSbatCommonDBInterface  executeCR_T_QUE_BOX_CR_SELECT_009(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());
		paramList.setValue(param[1].toString());
		paramList.setValue(param[2].toString());
		
		// DBアクセスを実行します
		db_CR_T_QUE_BOX.selectBySqlDefine(paramList, CR_T_QUE_BOX_CR_SELECT_009);
		return db_CR_T_QUE_BOX.selectNext();
	}

	/**
	 * キューメンバーを検索する。（ロック有）
	 * @param param
	 * @return
	 * @throws Exception
	 */
	private JBSbatCommonDBInterface  executeCR_M_QUE_MEMBER_CR_SELECT_001(Object[] param) throws Exception
	{
		// バイント変数のリストを生成します
		JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
		paramList.setValue(param[0].toString());
		paramList.setValue(param[1].toString());

		// DBアクセスを実行します
		db_CR_M_QUE_MEMBER.selectBySqlDefine(paramList, CR_M_QUE_MEMBER_CR_SELECT_001);
		return db_CR_M_QUE_MEMBER.selectNext();
	}

	/**
	 * キューメンバーを物理削除する。
	 * @param setParam
	 * @throws Exception
	 */
	private void executeCR_M_QUE_MEMBER_PKDELETET(Object[] setParam) throws Exception
	{
		// 設定値のマップを作成します
		JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
		whereMap.setValue("QUE_BOX_NO", setParam[0]);
		whereMap.setValue("USER_ID", setParam[1]);
		
		// DBアクセスを実行します
		db_CR_M_QUE_MEMBER.deleteByPrimaryKeys(whereMap);
	}
	
	/**
	 * キューメンバーを追加する
	 * @param setParam
	 * @throws Exception
	 */
	private void executeCR_M_QUE_MEMBER_PKINSERT(Object[] setParam) throws Exception
	{
		// 設定値のマップを作成します
		JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
		setMap.setValue("QUE_BOX_NO", setParam[0]);
		setMap.setValue("USER_ID", setParam[1]);
		setMap.setValue("ADD_DTM", setParam[2]);
		setMap.setValue("ADD_OPEACNT", setParam[3]);
		setMap.setValue("UPD_DTM", setParam[4]);
		setMap.setValue("UPD_OPEACNT", setParam[5]);
		setMap.setValue("DEL_DTM", setParam[6]);
		setMap.setValue("DEL_OPEACNT", setParam[7]);
		setMap.setValue("MK_FLG", setParam[8]);
	
		// DBアクセスを実行します
		db_CR_M_QUE_MEMBER.insertByPrimaryKeys(setMap);
	}
	
	/**
	 * 単項目チェック
	 * @param rsMap
	 * @return
	 */
	private String singleCheck(JBSbatServiceInterfaceMap rsMap)
	{
		// 単項目チェックを行います
		String strValue = null;

		// ユーザＩＤ項目チェック
		strValue = (String)rsMap.get(JBSbatCRIFM003.WORKER_NO);
		
		// 必須チェック
		if(JKKStringUtil.isNullBlank(strValue))
		{
			return ERR_CD_E020;
		}
		// 桁数チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"ketasuu2", "6", "10"}))
		{
			return ERR_CD_E020;
		}
		
		// 属性チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"hannkakuesuuji1"}))
		{
			return ERR_CD_E020;
		}

		// キューBOX番号項目チェック
		strValue = (String)rsMap.get(JBSbatCRIFM003.QUE_BOX_NO);
		
		// 必須チェック
		if(JKKStringUtil.isNullBlank(strValue))
		{
			return ERR_CD_E030;
		}
		// 桁数チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"ketasuu1","10"}))
		{
			return ERR_CD_E030;
		}
		
		// 属性チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"hannkakuesuuji1"}))
		{
			return ERR_CD_E030;
		}

		// 追加／削除フラグ項目チェック
		strValue = (String)rsMap.get(JBSbatCRIFM003.ADD_DEL_FLG);
		
		// 必須チェック
		if(JKKStringUtil.isNullBlank(strValue))
		{
			return ERR_CD_E040;
		}
		// 桁数チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"ketasuu1","1"}))
		{
			return ERR_CD_E040;
		}
		
		// 属性チェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"hannkakusuuji1"}))
		{
			return ERR_CD_E040;
		}
		
		// リファレンスチェック
		if(!JBSbatCheckUtil.invoke(strValue, new String[]{"ref_chk1", MODE_ADD + "," + MODE_DEL}))
		{
			return ERR_CD_E040;
		}

		return NO_ERROR;
	}
	/**
	 * データチェック
	 * @param recordMap
	 * @return チェックした結果をコードで返す。
	 * @throws Exception 
	 */
	private String checkData(JBSbatServiceInterfaceMap recordMap) throws Exception
	{
		// (a)ファイルチェック

		// フォーマットチェック
		if (recordMap.isInputErrorFlg())
		{
			// １レコードの項目数が異なる
			super.logPrint.printDebugLog("１レコードの項目数が異なる");
			return ERR_CD_E010;
		}
		
		// 必須・属性・桁数チェック
		String result = singleCheck(recordMap);
		
		if (!NO_ERROR.equals(result))
		{
			super.logPrint.printDebugLog("必須・属性・桁数チェックエラー");
			return result;
		}

		// (b) 登録内容チェック

		// ユーザ情報を取得
		String userId = recordMap.getString(JBSbatCRIFM003.WORKER_NO);
		
		JBSbatCommonDBInterface userInfo = executeZM_M_USER_CR_SELECT_002(new String[]{userId, this.opeDate, this.opeDate});
		
		if (userInfo == null)
		{
			super.logPrint.printDebugLog("ユーザが存在しないもしくは、権限が存在しない");
			return ERR_CD_E100;
		}
		
		String queBoxNo = recordMap.getString(JBSbatCRIFM003.QUE_BOX_NO);
		JBSbatCommonDBInterface queBoxInfo = executeCR_T_QUE_BOX_CR_SELECT_009(new String[]{userId, queBoxNo, queBoxNo});
		if (queBoxInfo == null)
		{
			super.logPrint.printDebugLog("キューＢＯＸが存在しない");
			return ERR_CD_E110;
		}
		if (MODE_ADD.equals(recordMap.getString(JBSbatCRIFM003.ADD_DEL_FLG)))
		{
			// ユーザが存在する場合
			if (userId.equals(queBoxInfo.getString(JBSbatZM_M_USER.USER_ID)))
			{
				super.logPrint.printDebugLog("キューメンバーが存在する");
				return ERR_CD_E120;
				
			}
		}
		else 
		{
			// ユーザが存在しない場合
			if (queBoxInfo.getString(JBSbatZM_M_USER.USER_ID) == null)
			{
				super.logPrint.printDebugLog("キューメンバーが存在しない");
				return ERR_CD_E130;
			}
			// 登録件数が１件の場合
			String userCount = queBoxInfo.getString("CNT");
			if (userCount != null && Integer.parseInt(userCount) == 1)
			{
				super.logPrint.printDebugLog("最後のキューメンバーを削除");
				return ERR_CD_E140;
			}
		}
		return NO_ERROR;
	}
	
	/**
	 * キュー権限一括登録結果の明細を作成
	 * @param inMap
	 * @param errCode
	 * @return
	 */
	private JBSbatServiceInterfaceMap createResultFile(JBSbatServiceInterfaceMap inMap,  String errCode)
	{
		JBSbatServiceInterfaceMap result = new JBSbatServiceInterfaceMap();
		
		// 各項目を設定する
		result.set(JBSbatCRIFM004.WORKER_NO, inMap.get(JBSbatCRIFM003.WORKER_NO));
		result.set(JBSbatCRIFM004.QUE_BOX_NO, inMap.get(JBSbatCRIFM003.QUE_BOX_NO));
		result.set(JBSbatCRIFM004.ADD_DEL_FLG, inMap.get(JBSbatCRIFM003.ADD_DEL_FLG));

		// 結果を設定する
		if (NO_ERROR.equals(errCode))
		{
			result.set(JBSbatCRIFM004.RESULT, resultCodeMap.get(RST_OK));
			result.set(JBSbatCRIFM004.ERR_CD, "");
			result.set(JBSbatCRIFM004.ERR_RSN, "");
		}
		else 
		{
			result.set(JBSbatCRIFM004.RESULT, resultCodeMap.get(RST_NG));
			result.set(JBSbatCRIFM004.ERR_CD, errCode);
			result.set(JBSbatCRIFM004.ERR_RSN, errCodeMap.get(errCode));
		}
		result.setOutFlg(true);
		return result;
	}	

	/**
	 * ディレイド実行結果を登録する
	 * @param shoriIraiNo
	 * @param outputBean
	 * @param inFileRecordCnt
	 * @param checkErr
	 * @throws Exception
	 */
	private void addDownloadFile(String shoriIraiNo, ArrayList<JBSbatServiceInterfaceMap> outRecs) throws Exception
	{
		boolean hasError = false;
		
		// データを読み込み
		JBSbatOutputItem outputBean = new JBSbatOutputItem();
		for (JBSbatServiceInterfaceMap outMap : outRecs) {
			if (!"".equals(outMap.get(JBSbatCRIFM004.ERR_CD)))
			{
				hasError = true;
			}
			outMap.setOutFlg(true);
			outputBean.addOutMapList(outMap);
		}

		// ファイル名などの出力ファイル情報をフリー項目から取得
		String[] outMidFile = freeItem.split(JKKBatConst.S_PARAM_DELIM);
				
		// キュー権限一括登録結果ファイルの出力先パスを取得（スラッシュ付）
		String outFilePath = outMidFile[0];
		
		// キュー権限一括登録結果ファイルのファイル名を編集
		String sysDateTimeStamp = JCCBatCommon.getSysDateTimeStamp();
		String timeStamp = sysDateTimeStamp.substring(8);
		String opeDateTime = super.onlineOpeDate + timeStamp;
		String outFileName =  "CRIFM004001_" + opeDateTime + ".csv";

		String outFileFullPath = outFilePath + outFileName;
		
		// キュー権限一括登録結果ファイルをファイル出力する
		JKKBatOutputUtil.editOutFile(super.commonItem, outputBean, "CRIFM004", outFilePath, outFileName);

		// 処理管理番号の取得を行う
		String trn_kanri_no = "000000000154";
		super.logPrint.printDebugLog("処理依頼番号：" + shoriIraiNo);
		JBSbatCommonDBInterface dateIkKriInfo = executeZM_T_DATAIKTTRK_KNRI_KK_SELECT_002(new String[]{shoriIraiNo});
		if (null != dateIkKriInfo)
		{
			trn_kanri_no = dateIkKriInfo.getString("TRN_KANRI_NO");
		}
		// 電子ファイル管理に登録する日本語のファイル名
		String outFileNhngName = "キュー権限一括登録結果ファイル_" + opeDateTime + ".csv";
		
		if (hasError)
		{
			// チェックエラーありのため、ディレイド処理依頼結果コードを"業務エラー"で更新
			HashMap<String, String> retMap = JCCbatShoriIraiUtil.updateShoriIraiResult(commonItem, shoriIraiNo, "2", outFileFullPath);
			// エラーファイルの電子ファイル管理番号取得して、ダウンロードファイル管理に登録
			String eFileKanriNo = retMap.get("EFILE_KAMRI_NO");
			if(!JKKStringUtil.isNullBlank(eFileKanriNo))
			{
				insertZM_T_DL_FILE_KANRI(eFileKanriNo, outFileNhngName, outFileFullPath, outRecs.size(), trn_kanri_no);
			}
		}
		else
		{
			// チェックエラーなしのため、ディレイド処理依頼結果コードを"完了"で更新
			JCCbatShoriIraiUtil.updateShoriIraiResult(commonItem, shoriIraiNo, "1", null);

			super.logPrint.printDebugLog("ファイルのフルパス：" + outFileFullPath);

			// キュー権限一括登録結果ファイルを電子ファイル管理スキーマに設定
			String[] denshiRet = JCCBatCommon.createDenshiFile(super.commonItem, "0000", outFileFullPath, null);
			
			// ダウンロードファイル管理に登録
			insertZM_T_DL_FILE_KANRI(denshiRet[0], outFileNhngName, outFileFullPath, outRecs.size(), trn_kanri_no);
		}
	}
	
	/**
	 * 主処理
	 * @return JBSbatOutputItem　出力情報
	 * @throws Exception
	 */
	public JBSbatOutputItem execute() throws Exception
	{
		/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
		List<HashMap<String, Object>> shoriIraiList = new ArrayList<HashMap<String, Object>>();
		shoriIraiList = JCCbatShoriIraiUtil.getShoriIraiInfo(commonItem, this.jobid);
		if (shoriIraiList == null)
		{
			// 対象データが存在しないため処理終了
			return null;
		}
		// キュー権限一括登録エラーコード取得
		errCodeMap = executeZM_M_CD_NM_KANRI_KK_SELECT_004(new String[] {CD_NM_KANRI_QUE_IKT_ADD_ERR_CD, super.opeDate, super.opeDate});

		// キュー権限一括登録結果コード取得
		resultCodeMap = executeZM_M_CD_NM_KANRI_KK_SELECT_004(new String[] {CD_NM_KANRI_QUE_IKT_ADD_RSLT_CD, super.opeDate, super.opeDate});

		int infoCount = 0;
		int errorCount = 0;

		for(HashMap<String, Object> shoriIrai : shoriIraiList)
		{
			// ▽▽▽ ファイル単位の処理開始 ▽▽▽
			// キュー権限一括登録結果ファイルへの登録用リスト
			ArrayList<JBSbatServiceInterfaceMap> queAuthIktRsltFileList = new ArrayList<JBSbatServiceInterfaceMap>();

			// 入力ファイルの定義取得
			String inDefFileName = JBSbatAplConst.getAplConstValue("IND") + "CRIFM003.def";

			// ディレイド処理依頼番号
			String shoriIraiNo = (String)shoriIrai.get(JBSbatCC_T_DLYD_TRN_REQ.DLYD_TRN_REQ_NO);

			// 入力電子ファイル管理番号
			String fileKanriNo = (String)shoriIrai.get(JBSbatCC_T_DLYD_TRN_REQ.INPUT_EFILE_KANRI_NO);
			
			// 電子ファイル管理よりキュー権限変更依頼ファイルの復元
			String inFilePath = JCCBatCommon.searchDenshiFile(commonItem, fileKanriNo);

			// 入力ファイル
			JBSbatInputFileUtil inFileUtil = new JBSbatInputFileUtil(inFilePath);
			// 定義ファイル
			JBSbatDefFileUtil inFileDef = new JBSbatDefFileUtil(inDefFileName, inFileUtil);
			
			super.logPrint.printDebugLog("処理日  ＝" + super.opeDate);
			super.logPrint.printDebugLog("ディレイド処理依頼番号  ＝" + shoriIraiNo);
			super.logPrint.printDebugLog("入力電子ファイル管理番号＝" + fileKanriNo);
			super.logPrint.printDebugLog("キュー権限変更依頼のファイルパス＝" + inFilePath);
			
			// ファイル単位の変数定義
			// 入力ファイルのレコード件数
			int inFileRecordCnt = 0;

			// 読み込み開始
			inFileUtil.createReader();
			
			// EOFになるまで読み込む
			while (inFileUtil.ready()) 
			{
				// ▽▽▽１行単位の処理開始 ▽▽▽
				// ファイルから１レコード取得
				String line = inFileUtil.readLine();
				
				// レコード件数カウント
				inFileRecordCnt++;
				
				// １レコードの情報をマップに格納
				JBSbatServiceInterfaceMap recordMap = inFileDef.lineToObject(line, inFileUtil, inFileRecordCnt);
				
				// 登録チェック処理
				String errCd = checkData(recordMap);
				if (!NO_ERROR.equals(errCd))
				{
					super.logPrint.printDebugLog("エラー発生：" + infoCount);
					queAuthIktRsltFileList.add(createResultFile(recordMap, errCd));
					infoCount++;
					// 次レコードを処理
					continue;
				}
				
				// キューメンバーへの登録
				try
				{
					String userId = recordMap.getString(JBSbatCRIFM003.WORKER_NO);
					String queBoxNo = recordMap.getString(JBSbatCRIFM003.QUE_BOX_NO);
					if (MODE_ADD.equals(recordMap.get(JBSbatCRIFM003.ADD_DEL_FLG).toString()))
					{
						// 追加
						Object[] params = new Object[] {queBoxNo, userId, null, null, null, null, null, null, null};

						executeCR_M_QUE_MEMBER_PKINSERT(params);
					}
					else 
					{
						// レコードをロックする
						JBSbatCommonDBInterface rec = executeCR_M_QUE_MEMBER_CR_SELECT_001(new Object[] {queBoxNo, userId});
						if (rec != null)
						{
							// 削除を実行
							executeCR_M_QUE_MEMBER_PKDELETET(new Object[] {queBoxNo, userId});
						}
					}

					// 正常に登録したため、正常としてファイル出力を行う
					queAuthIktRsltFileList.add(createResultFile(recordMap, NO_ERROR));
				}
				catch (Throwable e)
				{
					// エラーコード設定
					queAuthIktRsltFileList.add(createResultFile(recordMap, ERR_CD_E200));
					//フレームワークがエラーログにスタックトレースを出さないので、独自にエラーログ出力する
					super.logPrint.printErrMsg(JPCBatchMessageConstant.ECCB0110CE, e, new String[]{});
					errorCount++;
					// 次レコードを処理
					continue;
				}
				// △△△１行単位の処理終了 △△△
			}
			
			// キュー権限一括登録結果ファイル出力
			if(!queAuthIktRsltFileList.isEmpty())
			{
				// データ出力
				JBSbatOutputItem outputBean = new JBSbatOutputItem();
				for (JBSbatServiceInterfaceMap outMap : queAuthIktRsltFileList) {
					outMap.setOutFlg(true);
					outputBean.addOutMapList(outMap);
				}
				// ダウンロードファイルに登録
				addDownloadFile(shoriIraiNo, queAuthIktRsltFileList);
			}
			// ファイル単位でコミットする。
			this.commit();
			// △△△ ファイル単位の処理終了 △△△
		}

		// 1件以上チェックエラーがあった場合
		if (0 < infoCount)
		{
			JCRBatCommon.printShoriCountLog(commonItem, "チェックエラー件数", infoCount);
		}
		
		// エラー（業務エラー、システムエラー）が存在する場合
		if (0 < errorCount)
		{
			// 単一サービス呼び出しパターンの場合は、エラー件数を設定することで警告終了する
			commonItem.setErrorCount(errorCount);
		}

		return null;
		/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
		
	}
	
	/**
	 * 業務サービス終了処理
	 * @throws Exception
	 */
	@Override
	public void terminal() throws Exception {
		/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
		/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
		db_CC_T_EFILE_KANRI.close();
		db_CR_T_QUE_BOX.close();
		db_CR_M_QUE_MEMBER.close();
		db_ZM_M_USER.close();
		db_ZM_M_CD_NM_KANRI.close();
		db_ZM_T_DATAIKTTRK_KNRI.close();
		db_ZM_T_DL_FILE_KANRI.close();
		/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
		/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
	}

}