/********************************************************************* * All Rights reserved,Copyright (c) K-Opticom ********************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JBSbatKKBcasStcTkDataSksi * ソースファイル名 ：JBSbatKKBcasStcTkDataSksi.java * 作成者 ：富士通　 * 作成日 ：2012年05月11日 *＜機能概要＞ *　B-CAS設置・撤去データ作成部品です。 *＜修正履歴＞ * バージョン 修正日 修正者 修正内容 * v3.00.00 2012/05/11 FJ)岡田 新規作成 * v3.01.00 2012/07/03 FJ)団 FTP送信対応 * v3.02.00 2012/10/15 FJ)岡田 【ST1-2012-0000605】障害対応 * v3.03.00 2012/11/23 FJ)柳 【TAI-2012-0000095】対応 * v4.00.00 2012/12/15 FJ)柳 【IT1-2012-0002444】対応 * v4.00.01 2013/01/12 FJ)古内 【ST4-2013-0000045】対応 * v4.00.02 2013/02/06 FJ)松浦 【ST4-2013-0000045】対応 * v5.00.00 2013/07/05 FJ)岡田 【IT1-2013-0001369】TV残課題対応 * v5.00.01 2013/08/25 FJ)柳 【OM-2013-0000848】障害対応 * v6.00.00 2020/04/06 FJ)Eric 【ANK-3807-00-00】 *********************************************************************/ package eo.business.service; import java.io.BufferedWriter; import java.io.FileOutputStream; import java.io.IOException; import java.io.OutputStreamWriter; import java.util.ArrayList; import eo.business.common.JBSbatBusinessService; import eo.business.common.JKKBatConst; import eo.business.util.table.JBSbatKK_T_KKTK_SVC_KEI; import eo.business.util.table.JBSbatKK_T_SVKEI_EXC_CTRL; import eo.common.constant.JKKStrConst; import eo.common.constant.JPCBatchMessageConstant; 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.JBSbatDateUtil; import eo.framework.util.JBSbatStringUtil; /** * (クラスの機能概要)

*
* @author 富士通 */ public class JBSbatKKBcasStcTkDataSksi extends JBSbatBusinessService { /**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/ /** テーブル(機器提供サービス契約)*/ private static final String D_TBL_NAME_KK_T_KKTK_SVC_KEI = "KK_T_KKTK_SVC_KEI"; /** SQL定義キー(KK_SELECT_070)*/ private static final String KK_T_KKTK_SVC_KEI_KK_SELECT_070 = "KK_SELECT_070"; /** SQL定義キー(KK_SELECT_071)*/ private static final String KK_T_KKTK_SVC_KEI_KK_SELECT_071 = "KK_SELECT_071"; /** テーブルアクセスクラス(機器提供サービス契約)*/ private JBSbatSQLAccess db_KK_T_KKTK_SVC_KEI = null; /**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/ /** テーブル(機器提供サービス契約)*/ private static final String D_TBL_NAME_KK_T_KKTK_SVC_KEI_071 = "KK_T_KKTK_SVC_KEI"; /** テーブル(サービス契約排他制御)*/ private static final String D_TBL_NAME_KK_T_SVKEI_EXC_CTRL = "KK_T_SVKEI_EXC_CTRL"; /** テーブルアクセスクラス(機器提供サービス契約)*/ private JBSbatSQLAccess db_KK_T_KKTK_SVC_KEI_071 = null; /** テーブルアクセスクラス(サービス契約排他制御)*/ private JBSbatSQLAccess db_KK_T_SVKEI_EXC_CTRL = null; /** * B-CASデータ（設置分）送信ファイル名 */ private static final String FILE_NAME_STC = "KKIFE169_SETCHI_"; /** * B-CASデータ（解約分）送信ファイル名 */ private static final String FILE_NAME_DSL = "KKIFE170_TEKKYO_"; /** * エンコード */ private static final String ENCODE = "Shift-JIS"; /** * 改行コードCRLF */ private static final String LINE_SEPARAOR_CRLF = "\r\n"; /** * FREE項目数 */ private static final int FREE_ITEM = 6; /** * eoTV機器設置承認状態コード（1：承認済） */ private static final String EO_TV_KKST_SNN_STAT_CD_SNN_ZM = "1"; /** * 設置データ判定用（1：設置データ） */ private static final String STC_FLG_STC = "1"; /** * 設置データ判定用（0：撤去データ） */ private static final String STC_FLG_TKY = "0"; /** * 外部インターフェイスファイル「B-CASデータ（設置分）送信」ファイルパス */ private String gaibu_stc_file_path = ""; /** * ソート前中間ファイル「B-CASデータ設置分送信データファイル」フルパスファイル名 */ private String mid_stc_fl_fullpath = ""; /** * 外部インターフェイスファイル「B-CASデータ（解約分）送信」ファイルパス */ private String gaibu_dsl_file_path = ""; /** * ソート前中間ファイル「B-CASデータ解約分送信データファイル」フルパスファイル名 */ private String mid_dsl_fl_fullpath = ""; /** * 設置ワークList（「B-CASデータ（設置分）送信ファイル」用ワーク領域） */ private ArrayList stcWkList = null; /** * 撤去ワークList（「B-CASデータ（解約分）送信」用ワーク領域） */ private ArrayList dslWkList = null; /** * 機器提供サービス契約番号List（設置データ重複判定用） */ private ArrayList kktkSvcKeiList = null; /** * 初期処理 * @param JBSbatCommonItem commonItem　バッチ共通パラメータ電文 * @throws Exception */ public void initial(JBSbatCommonItem commonItem) throws Exception { /**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/ /**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/ // 共通パラメータを設定します super.setCommonInfo(commonItem); // DBアクセスクラスを生成します db_KK_T_KKTK_SVC_KEI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_KKTK_SVC_KEI); /**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/ // DBアクセスクラスを生成します。 db_KK_T_KKTK_SVC_KEI_071 = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_KKTK_SVC_KEI_071); db_KK_T_SVKEI_EXC_CTRL = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_SVKEI_EXC_CTRL); // フリー項目値の取得をします。 String[] free_item = commonItem.getFreeItem().split(JKKBatConst.S_PARAM_DELIM); // パラメータ数チェックをします。 if (FREE_ITEM != free_item.length) { throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0130CE, new String[]{"FREE"}); } // フリー項目値をセットします。 // １．外部インターフェイスファイル「B-CASデータ（設置分）送信」ファイルパス gaibu_stc_file_path = free_item[0]; // ２．ソート前中間ファイル「B-CASデータ設置分送信データファイル」フルパスファイル名 mid_stc_fl_fullpath = free_item[1]; // ３．外部インターフェイスファイル「B-CASデータ（解約分）送信」ファイルパス gaibu_dsl_file_path = free_item[2]; // ４．ソート前中間ファイル「B-CASデータ解約分送信データファイル」フルパスファイル名 mid_dsl_fl_fullpath = free_item[3]; // ５．Ｂ−ＣＡＳ設置データを取得 // １．機器提供サービス契約番号 // ２．機器製造番号 // ３．サービス契約番号 // ４．世代登録年月日時分秒 JBSbatInputFileUtil tmpReader = new JBSbatInputFileUtil(free_item[4]); tmpReader.setEncode(JKKBatConst.SJIS); // 文字コード tmpReader.setLine(JKKStrConst.LINE_LF); // 改行コード tmpReader.createReader(); try { // 取得した設置データの機器提供サービス契約番号を格納します。（重複判定用） kktkSvcKeiList = new ArrayList(); ArrayList tmpList = new ArrayList(); stcWkList = new ArrayList(); String line = null; JBSbatCommonDBInterface outMap = null; while (null != (line = tmpReader.readLine())) { String[] dataList = line.split(JKKBatConst.S_SEP_CAM); outMap = getKktkSvcKeiLineList(dataList); if (null != outMap) { tmpList.add(outMap); } } stcWkList = tmpList; } catch (IOException e) { throw new JBSbatBusinessException("EKKB0020CE", new String[]{free_item[4]}); } finally { tmpReader.close(); } // ６．Ｂ−ＣＡＳ撤去データを取得 // １．機器提供サービス契約番号 // ２．機器製造番号 // ３．サービス契約番号 // ４．世代登録年月日時分秒 tmpReader = new JBSbatInputFileUtil(free_item[5]); tmpReader.setEncode(JKKBatConst.SJIS); // 文字コード tmpReader.setLine(JKKStrConst.LINE_LF); // 改行コード tmpReader.createReader(); try { ArrayList tmpList = new ArrayList(); dslWkList = new ArrayList(); String line = null; JBSbatCommonDBInterface outMap = null; while (null != (line = tmpReader.readLine())) { String[] dataList = line.split(JKKBatConst.S_SEP_CAM); outMap = getKktkSvcKeiLineList(dataList); if (null != outMap) { tmpList.add(outMap); } } dslWkList = tmpList; } catch (IOException e) { throw new JBSbatBusinessException("EKKB0020CE", new String[]{free_item[5]}); } finally { tmpReader.close(); } super.logPrint.printDebugLog("gaibu_stc_file_path：：：" + gaibu_stc_file_path); super.logPrint.printDebugLog("mid_stc_fl_fullpath：：：" + mid_stc_fl_fullpath); super.logPrint.printDebugLog("gaibu_dsl_file_path：：：" + gaibu_dsl_file_path); super.logPrint.printDebugLog("mid_dsl_fl_fullpath：：：" + mid_dsl_fl_fullpath); super.logPrint.printDebugLog("input_stc_file_fullpath：" + free_item[4]); super.logPrint.printDebugLog("input_dsl_file_fullpath：" + free_item[5]); /**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/ } /** * 主処理 * @return JBSbatOutputItem　出力情報 * @throws Exception */ public JBSbatOutputItem execute() throws Exception { /**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/ super.logPrint.printDebugLog("execute_START"); // 3. B-CAS設置・撤去データ（カード交換分）データ取得 // 検索用パラメタをセットします。 String [] kktkSvcKei_070_whereParam = {super.opeDate}; // 異動予約.予約適用年月日 // B-CAS設置・撤去データ（カード交換分）取得検索：SQL定義キー（KK_T_KKTK_SVC_KEI_KK_SELECT_070）を実行します。 executeKK_T_KKTK_SVC_KEI_KK_SELECT_070(kktkSvcKei_070_whereParam); // B-CAS設置・撤去データ（カード交換分）データを設置、撤去ワークリストに格納 this.setBcasStcDslTgDataSet(); // 4. B-CASデータ（設置分）送信ファイル作成 // B-CASデータ（設置分）データファイル作成 this.executeOutFileWrite(stcWkList,mid_stc_fl_fullpath); //ANK-3807-00-00 DEL START // B-CASデータ（設置分）送信件数、フラグファイル作成 //this.executeOutFileCntFlg(Integer.toString(stcWkList.size()), gaibu_stc_file_path,FILE_NAME_STC); //ANK-3807-00-00 DEL END // 5. B-CASデータ（撤去分）送信ファイル作成 // B-CASデータ（撤去分）データファイル作成 this.executeOutFileWrite(dslWkList,mid_dsl_fl_fullpath); //ANK-3807-00-00 DEL START // B-CASデータ（解約分）送信件数、フラグファイル作成 //this.executeOutFileCntFlg(Integer.toString(dslWkList.size()),gaibu_dsl_file_path, FILE_NAME_DSL); //ANK-3807-00-00 DEL END // B-CASデータ（設置分）更新 this.updateKktkSvcKei(); super.logPrint.printDebugLog("execute_END"); return null; /**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/ } /** * 業務サービス終了処理 * @throws Exception */ public void terminal() throws Exception { /**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/ /**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/ // DBアクセスクラスをクローズします db_KK_T_KKTK_SVC_KEI.close(); /**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/ // DBアクセスクラスをクローズします。 db_KK_T_KKTK_SVC_KEI_071.close(); db_KK_T_SVKEI_EXC_CTRL.close(); /**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/ } /**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/ /** * SQLKEY(KK_SELECT_070)でDBアクセスを行います。
*

* 処理フロー
* 

	 * 1.引数でバイント変数を設定します。

	 *
	 * 2.DBアクセスを実行します。

	 * 
	 * 3.メソッドの呼び出し方です。

	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	機器設置承認年月日
	 *
*

* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeKK_T_KKTK_SVC_KEI_KK_SELECT_070(Object[] param) throws Exception { // バイント変数のリストを生成します JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(param[0].toString()); // DBアクセスを実行します db_KK_T_KKTK_SVC_KEI.selectBySqlDefine(paramList, KK_T_KKTK_SVC_KEI_KK_SELECT_070); } /** * SQLKEY(KK_SELECT_071)でDBアクセスを行います。
*

* 処理フロー
* 

	 * 1.引数でバイント変数を設定します。

	 *
	 * 2.DBアクセスを実行します。

	 * 
	 * 3.メソッドの呼び出し方です。

	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	機器提供サービス契約番号
	 *		 	機器製造番号
	 *
*

* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeKK_T_KKTK_SVC_KEI_KK_SELECT_071(Object[] param) throws Exception { // バイント変数のリストを生成します JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(param[0].toString()); paramList.setValue(param[1].toString()); // DBアクセスを実行します db_KK_T_KKTK_SVC_KEI_071.selectBySqlDefine(paramList, KK_T_KKTK_SVC_KEI_KK_SELECT_071); } /** * PK(ＰＫ　更新)でDBアクセスを行います。
*

* 処理フロー
* 

	 * 1.引数で設定項目マップを作ります。

	 *
	 * 2.引数で条件マップを作ります。

	 *
	 * 3.DBアクセスを実行します。

	 * 
	 * 4.メソッドの呼び出し方です。

	 *		引数:
	 *		setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。
	 *		 	CASカード使用許諾年月日				CAS_CARD_USE_KYODAK_YMD
	 *		whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。
	 *		 	KKTK_SVC_KEI_NO
	 *		 	GENE_ADD_DTM
	 *
*

* @param setParam 設定項目の値。 * @param whereParam 条件項目の値。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeKK_T_KKTK_SVC_KEI_PKUPDATE(Object[] setParam, Object[] whereParam) throws Exception { // 設定値のマップを作成します JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface(); setMap.setValue("CAS_CARD_USE_KYODAK_YMD", setParam[0]); // 条件のマップを作成します JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface(); whereMap.setValue("KKTK_SVC_KEI_NO", whereParam[0]); whereMap.setValue("GENE_ADD_DTM", whereParam[1]); // DBアクセスを実行します db_KK_T_KKTK_SVC_KEI.updateByPrimaryKeys(whereMap, setMap); } /**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/ /** * B-CAS設置・撤去対象データセット。
*

* @throws Exception 業務サービス内で発生した例外全般。 */ private void setBcasStcDslTgDataSet() throws Exception { JBSbatCommonDBInterface kktkSvcKeiMap = null; JBSbatCommonDBInterface outMap = null; // 交換の場合確認用SQLパラメタ String[] kktkSvcKei_071_whereParam = new String[3]; // 機器提供サービス契約検索結果(KK_SELECT_070)件数分繰り返します。 for (kktkSvcKeiMap = db_KK_T_KKTK_SVC_KEI.selectNext(); null != kktkSvcKeiMap ; kktkSvcKeiMap = db_KK_T_KKTK_SVC_KEI.selectNext()) { // 機器提供サービス契約より、「B-CAS設置・撤去データ（カード交換分）」検索で取得したレコードに対して // 前の世代（機器製造番号違い）のレコードを１件取得します。 // 検索用パラメタをセットします。 kktkSvcKei_071_whereParam[0] = JBSbatStringUtil.Rtrim(kktkSvcKeiMap.getString(JBSbatKK_T_KKTK_SVC_KEI.KKTK_SVC_KEI_NO)); //機器提供サービス契約番号 kktkSvcKei_071_whereParam[1] = JBSbatStringUtil.Rtrim(kktkSvcKeiMap.getString(JBSbatKK_T_KKTK_SVC_KEI.KIKI_SEIZO_NO)); //機器製造番号 // 前世代データ取得検索：SQL定義キー（KK_T_KKTK_SVC_KEI_KK_SELECT_071）を実行します。 executeKK_T_KKTK_SVC_KEI_KK_SELECT_071(kktkSvcKei_071_whereParam); // レコードを取得します。 JBSbatCommonDBInterface kktkSvcKeiMap_071 = db_KK_T_KKTK_SVC_KEI_071.selectNext(); // 「前世代データ取得」検索結果がある場合、B-CAS設置・撤去対象として // B-CAS設置・撤去ワークListに１レコードずつ格納します。 if (null != kktkSvcKeiMap_071) { // 「B-CAS設置・撤去データ（カード交換分）取得」検索結果(KK_SELECT_070)を設置データ（変更後分）として // 設置ワークListに格納します。（設置データと重複レコードの場合、未格納） // 機器提供サービス契約検索結果１レコード取得メソッドを呼び出します。 outMap = this.getKktkSvcKeiLineList(kktkSvcKeiMap, STC_FLG_STC); if (null != outMap) { // 設置ワークListにレコードを格納します。 stcWkList.add(outMap); } // 「前世代データ取得」検索結果(KK_SELECT_071)を撤去データ（変更前分）として撤去ワークListに格納します。 // 機器提供サービス契約検索結果１レコード取得メソッドを呼び出します。 outMap = this.getKktkSvcKeiLineList(kktkSvcKeiMap_071, STC_FLG_TKY); if (null != outMap) { // 撤去ワークListにレコードを格納します。 dslWkList.add(outMap); } } // 「１世代前データ取得」検索結果がない場合、B-CAS設置・撤去対象外として次のレコードに進みます。 else { super.logPrint.printDebugLog( "「前世代データ取得」検索：SQL定義キー（KK_T_KKTK_SVC_KEI_KK_SELECT_071）検索結果なし。"); continue; } } } /** * 機器提供サービス契約検索結果１レコード取得。
*

* @param rsMap DB検索結果。 * @param stcFlg 設置データ判定用。「"1":設置データ」「"0":撤去データ」 * @return HashMap １レコード格納List。 * @throws Exception 業務サービス内で発生した例外全般。 */ private JBSbatCommonDBInterface getKktkSvcKeiLineList(JBSbatCommonDBInterface rsMap, String stcFlg) throws Exception { super.logPrint.printDebugLog("getKktkSvcKeiLineList_START"); JBSbatCommonDBInterface outmap = new JBSbatCommonDBInterface(); String kktkSvcKeiNo = ""; // 機器提供サービス契約番号 String kikiSeizoNo = ""; // 機器製造番号 String svcKeiNo = ""; // サービス契約番号 String geneAddDtm = ""; // 世代登録年月日時分秒 String eoTvKkstSnnStatCd = ""; // eoTV機器設置承認状態コード // 機器提供サービス契約番号 kktkSvcKeiNo = JBSbatStringUtil.Rtrim(rsMap.getString(JBSbatKK_T_KKTK_SVC_KEI.KKTK_SVC_KEI_NO)); // 機器製造番号 kikiSeizoNo = JBSbatStringUtil.Rtrim(rsMap.getString(JBSbatKK_T_KKTK_SVC_KEI.KIKI_SEIZO_NO)); // サービス契約番号 svcKeiNo = JBSbatStringUtil.Rtrim(rsMap.getString(JBSbatKK_T_KKTK_SVC_KEI.SVC_KEI_NO)); // 世代登録年月日時分秒 geneAddDtm = JBSbatStringUtil.Rtrim(rsMap.getString(JBSbatKK_T_KKTK_SVC_KEI.GENE_ADD_DTM)); // eoTV機器設置承認状態コード eoTvKkstSnnStatCd = JBSbatStringUtil.Rtrim(rsMap.getString(JBSbatKK_T_KKTK_SVC_KEI.EO_TV_KKST_SNN_STAT_CD)); // 機器製造番号とサービス契約番号の両方に値が無い場合 if ((null == kikiSeizoNo || kikiSeizoNo.length() ==0) && (null == svcKeiNo || svcKeiNo.length() ==0)) { // 機器製造番号とサービス契約番号の両方が未設定の場合、ワーニング出力してレコードスキップします。 super.logPrint.printBusinessErrorLog("EKKB0290AW", new String[]{"機器提供サービス契約番号：" + kktkSvcKeiNo + "のB-CAS IDとお客様IDの両方未設定"}); return null; } //撤去の場合には機器製造番号がない場合スキップ if (STC_FLG_TKY.equals(stcFlg)) { // 機器製造番号が無い場合 if ((kikiSeizoNo.length() ==0)) { // 機器製造番号が未設定の場合、ワーニング出力してレコードスキップします。 super.logPrint.printBusinessErrorLog("EKKB0290AW", new String[]{"機器提供サービス契約番号：" + kktkSvcKeiNo + "のB-CAS IDが未設定"}); return null; } } // 設置データの場合、機器提供サービス契約番号重複チェックを行います。 if (STC_FLG_STC.equals(stcFlg)) { super.logPrint.printDebugLog("stcFlg：" + stcFlg); // 機器提供サービス契約番号がリストに設定されている場合、重複レコードとして格納しません。 if (kktkSvcKeiList.contains(kktkSvcKeiNo)) { super.logPrint.printDebugLog("☆getKktkSvcKeiLineList☆"); super.logPrint.printDebugLog("機器提供サービス契約番号重複：スキップ"); super.logPrint.printDebugLog("機器提供サービス契約番号：" + kktkSvcKeiNo); return null; } } outmap.setValue(JBSbatKK_T_KKTK_SVC_KEI.KKTK_SVC_KEI_NO, kktkSvcKeiNo); outmap.setValue(JBSbatKK_T_KKTK_SVC_KEI.KIKI_SEIZO_NO, kikiSeizoNo); outmap.setValue(JBSbatKK_T_KKTK_SVC_KEI.SVC_KEI_NO, svcKeiNo); outmap.setValue(JBSbatKK_T_KKTK_SVC_KEI.GENE_ADD_DTM, geneAddDtm); outmap.setValue(JBSbatKK_T_KKTK_SVC_KEI.EO_TV_KKST_SNN_STAT_CD, eoTvKkstSnnStatCd); super.logPrint.printDebugLog("☆getKktkSvcKeiLineList☆"); super.logPrint.printDebugLog("機器提供サービス契約番号 ：" + kktkSvcKeiNo); super.logPrint.printDebugLog("機器製造番号 ：" + kikiSeizoNo); super.logPrint.printDebugLog("サービス契約番号 ：" + svcKeiNo); super.logPrint.printDebugLog("世代登録年月日時分秒 ：" + geneAddDtm); super.logPrint.printDebugLog("eoTV機器設置承認状態コード：" + eoTvKkstSnnStatCd); super.logPrint.printDebugLog("getKktkSvcKeiLineList_END"); return outmap; } /** * 機器提供サービス契約検索結果１レコード取得。
* （csvファイルからの読み込み）
*

* @param dataList CSVファイルの１レコード分データ * @return outmap １レコード格納List。 * @throws Exception 業務サービス内で発生した例外全般。 */ private JBSbatCommonDBInterface getKktkSvcKeiLineList(String[] dataList) throws Exception { super.logPrint.printDebugLog("getKktkSvcKeiLineList(csv)_START"); JBSbatCommonDBInterface outmap = new JBSbatCommonDBInterface(); String kktkSvcKeiNo = ""; // 機器提供サービス契約番号 String kikiSeizoNo = ""; // 機器製造番号 String svcKeiNo = ""; // サービス契約番号 String geneAddDtm = ""; // 世代登録年月日時分秒 String eoTvKkstSnnStatCd = ""; // eoTV機器設置承認状態コード // 機器提供サービス契約番号 kktkSvcKeiNo = JBSbatStringUtil.trim(dataList[0].substring(1, dataList[0].length()-1)); // 機器製造番号 kikiSeizoNo = JBSbatStringUtil.trim(dataList[5].substring(1, dataList[5].length()-1)); // サービス契約番号 svcKeiNo = JBSbatStringUtil.trim(dataList[6].substring(1, dataList[6].length()-1)); // 世代登録年月日時分秒 geneAddDtm = JBSbatStringUtil.trim(dataList[1].substring(1, dataList[1].length()-1)); // eoTV機器設置承認状態コード eoTvKkstSnnStatCd = JBSbatStringUtil.trim(dataList[13].substring(1, dataList[13].length()-1)); // 機器製造番号とサービス契約番号の両方に値が無い場合 if ((null == kikiSeizoNo || kikiSeizoNo.length() ==0) && (null == svcKeiNo || svcKeiNo.length() ==0)) { // 機器製造番号とサービス契約番号の両方が未設定の場合、ワーニング出力してレコードスキップします。 super.logPrint.printBusinessErrorLog("EKKB0290AW", new String[]{"機器提供サービス契約番号：" + kktkSvcKeiNo + "のB-CAS IDとお客様IDの両方未設定"}); return null; } // 設置ファイル出力対象の機器提供サービス契約番号を重複チェック用に保持します。 kktkSvcKeiList.add(kktkSvcKeiNo); outmap.setValue(JBSbatKK_T_KKTK_SVC_KEI.KKTK_SVC_KEI_NO, kktkSvcKeiNo); outmap.setValue(JBSbatKK_T_KKTK_SVC_KEI.KIKI_SEIZO_NO, kikiSeizoNo); outmap.setValue(JBSbatKK_T_KKTK_SVC_KEI.SVC_KEI_NO, svcKeiNo); outmap.setValue(JBSbatKK_T_KKTK_SVC_KEI.GENE_ADD_DTM, geneAddDtm); outmap.setValue(JBSbatKK_T_KKTK_SVC_KEI.EO_TV_KKST_SNN_STAT_CD, eoTvKkstSnnStatCd); super.logPrint.printDebugLog("★getKktkSvcKeiLineList(csv)★"); super.logPrint.printDebugLog("機器提供サービス契約番号 ：" + kktkSvcKeiNo); super.logPrint.printDebugLog("機器製造番号 ：" + kikiSeizoNo); super.logPrint.printDebugLog("サービス契約番号 ：" + svcKeiNo); super.logPrint.printDebugLog("世代登録年月日時分秒 ：" + geneAddDtm); super.logPrint.printDebugLog("eoTV機器設置承認状態コード：" + eoTvKkstSnnStatCd); super.logPrint.printDebugLog("getKktkSvcKeiLineList(csv)_END"); return outmap; } /** * B-CASデータ（設置分・解約分）送信データファイル出力。
*

* @param lineList 対象List１レコード。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeOutFileWrite( ArrayList list, String path) throws Exception { BufferedWriter out_writer = null; try { out_writer = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(path), ENCODE)); StringBuilder fileData = null; // 設置ワークList件数分繰り返します。 for (int i = 0; i < list.size(); i++) { // 設置ワークListから１レコード取り出します。 JBSbatCommonDBInterface outMap = list.get(i); // B-CASデータ（設置分・解約分）送信データファイル出力メソッドを呼び出し、 // ソート前中間ファイル「B-CASデータ（設置分）送信データファイル」を出力します。 // データファイル情報保持用StringBuilderオブジェクトを生成します。 fileData = new StringBuilder(); // B-CASデータ（設置分・解約分）送信データファイル項目を設定します。 fileData.append(outMap.getString(JBSbatKK_T_KKTK_SVC_KEI.KIKI_SEIZO_NO)); // 機器製造番号 fileData.append(JKKBatConst.CONMA); // 区切り文字「,」 fileData.append(outMap.getString(JBSbatKK_T_KKTK_SVC_KEI.SVC_KEI_NO)); // サービス契約番号 fileData.append(LINE_SEPARAOR_CRLF); // 改行コード「CRLF」 // ファイルを出力します。 out_writer.write(fileData.toString()); } out_writer.flush(); } catch (IOException e) { throw new JBSbatBusinessException("EKKB0250CE", new String[]{path, e.getMessage()}); } finally { if (null != out_writer) { out_writer.close(); } } } /** * 件数ファイル、フラグファイル出力。
*

* @param dataCnt データ件数。 * @param filePath 作成パース。 * @param fileName ファイル名作成用変数。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeOutFileCntFlg(String dataCnt, String filePath, String fileName) throws Exception { // 件数ファイルを作成します。 BufferedWriter out_writer_cnt = null; try { // 件数ファイルを生成します。 out_writer_cnt = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(filePath + fileName + ".cnt"), ENCODE)); out_writer_cnt.write("\"" + dataCnt + "\""); out_writer_cnt.write("\n"); // 件数ファイルを出力します。 out_writer_cnt.flush(); super.logPrint.printDebugLog("件数ファイル出力 ：" + filePath + fileName + ".cnt"); } catch (IOException e) { throw new JBSbatBusinessException("EKKB0250CE", new String[]{filePath + fileName + ".cnt", e.getMessage()}); } finally { if (null != out_writer_cnt) { // 件数ファイルをクローズします。 out_writer_cnt.close(); } } // フラグファイルを作成します。 BufferedWriter out_writer_flg = null; try { // フラグファイルを生成します。 out_writer_flg = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(filePath + fileName + ".flg"), ENCODE)); // フラグファイルを出力します。 out_writer_flg.flush(); super.logPrint.printDebugLog("フラグファイル出力：" + filePath + fileName + ".flg"); } catch (IOException e) { throw new JBSbatBusinessException("EKKB0250CE", new String[]{filePath + fileName + ".flg", e.getMessage()}); } finally { if (null != out_writer_flg) { // フラグファイルをクローズします。 out_writer_flg.close(); } } } /** * 機器提供サービス契約情報の更新処理を行います。
*

* @throws Exception メソッド内で発生した例外全般。 */ private void updateKktkSvcKei() throws Exception { super.logPrint.printDebugLog("updateKktkSvcKei_START"); JBSbatCommonDBInterface whereMap = null; JBSbatCommonDBInterface haitaMap = null; for (int i = 0 ; i *

* @param kktkSvcKeiNo 機器提供サービス契約番号。 * @param geneAddDtm 世代登録年月日時分秒。 * @throws Exception メソッド内で発生した例外全般。 */ private void updateKktkSvcKeiSnn(String kktkSvcKeiNo, String geneAddDtm) throws Exception { super.logPrint.printDebugLog("updateKktkSvcKeiSnn_START"); // 機器提供サービス契約更新 設定パラメータ String[] setParam = new String[1]; // 機器提供サービス契約更新 検索パラメータ String[] whereParam = new String[2]; // 機器提供サービス契約更新 設定パラメータ setParam[0] = super.opeDate; // CASカード使用許諾年月日 // 機器提供サービス契約更新 検索パラメータ whereParam[0] = kktkSvcKeiNo; // 機器提供サービス契約番号 whereParam[1] = geneAddDtm; // 世代登録年月日時分秒 super.logPrint.printDebugLog("whereParam(機器提供サービス契約番号)：" + whereParam[0]); super.logPrint.printDebugLog("whereParam(世代登録年月日時分秒)：：：" + whereParam[1]); super.logPrint.printDebugLog("setParam(CAS_CARD_USE_KYODAK_YMD) ：：" + setParam[0]); // 機器提供サービス契約更新（承認済パターン） executeKK_T_KKTK_SVC_KEI_PKUPDATE(setParam, whereParam); super.logPrint.printDebugLog("updateKktkSvcKeiSnn_END"); } /** * 機器提供サービス契約情報の更新処理（未承認パターン）を行います。
*

* @param kktkSvcKeiNo 機器提供サービス契約番号。 * @param geneAddDtm 世代登録年月日時分秒。 * @throws Exception メソッド内で発生した例外全般。 */ private void updateKktkSvcKeiMiSnn(String kktkSvcKeiNo, String geneAddDtm) throws Exception { super.logPrint.printDebugLog("updateKktkSvcKeiMiSnn_START"); // 機器提供サービス契約更新 設定パラメータ String[] setParam = new String[3]; // 機器提供サービス契約更新 検索パラメータ String[] whereParam = new String[2]; // 機器提供サービス契約更新 設定パラメータ setParam[0] = EO_TV_KKST_SNN_STAT_CD_SNN_ZM; // eoTV機器設置承認状態コード setParam[1] = super.opeDate; // 機器設置承認年月日 setParam[2] = super.opeDate; // CASカード使用許諾年月日 // 機器提供サービス契約更新 検索パラメータ whereParam[0] = kktkSvcKeiNo; // 機器提供サービス契約番号 whereParam[1] = geneAddDtm; // 世代登録年月日時分秒 super.logPrint.printDebugLog("whereParam(機器提供サービス契約番号)：" + whereParam[0]); super.logPrint.printDebugLog("whereParam(世代登録年月日時分秒)：：：" + whereParam[1]); super.logPrint.printDebugLog("setParam(EO_TV_KKST_SNN_STAT_CD)：：：" + setParam[0]); super.logPrint.printDebugLog("setParam(KKST_SNN_YMD)：：：：：：：：" + setParam[1]); super.logPrint.printDebugLog("setParam(CAS_CARD_USE_KYODAK_YMD) ：：" + setParam[2]); // 機器提供サービス契約更新（未承認パターン） executeKK_T_KKTK_SVC_KEI_PKUPDATE2(setParam, whereParam); super.logPrint.printDebugLog("updateKktkSvcKeiMiSnn_END"); } /** * PK(ＰＫ　更新)でDBアクセスを行います。
*

* 処理フロー
* 

	 * 1.引数で設定項目マップを作ります。

	 *
	 * 2.引数で条件マップを作ります。

	 *
	 * 3.DBアクセスを実行します。

	 * 
	 * 4.メソッドの呼び出し方です。

	 *		引数:
	 *		setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。
	 *		 	eoTV機器設置承認状態コード			EO_TV_KKST_SNN_STAT_CD
	 *		 	機器設置承認年月日					KKST_SNN_YMD
	 *		 	CASカード使用許諾年月日				CAS_CARD_USE_KYODAK_YMD
	 *		whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。
	 *		 	KKTK_SVC_KEI_NO
	 *		 	GENE_ADD_DTM
	 *
*

* @param setParam 設定項目の値。 * @param whereParam 条件項目の値。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeKK_T_KKTK_SVC_KEI_PKUPDATE2(Object[] setParam, Object[] whereParam) throws Exception { // 設定値のマップを作成します。 JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface(); setMap.setValue("EO_TV_KKST_SNN_STAT_CD", setParam[0]); setMap.setValue("KKST_SNN_YMD", setParam[1]); setMap.setValue("CAS_CARD_USE_KYODAK_YMD", setParam[2]); // 条件のマップを作成します。 JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface(); whereMap.setValue("KKTK_SVC_KEI_NO", whereParam[0]); whereMap.setValue("GENE_ADD_DTM", whereParam[1]); // DBアクセスを実行します。 db_KK_T_KKTK_SVC_KEI.updateByPrimaryKeys(whereMap, setMap); } /** * サービス契約排他制御への更新処理を行います。
*

* 処理フロー
* 

	 * 1.更新処理を実行します。

	 * 
	 *
*

* @param svcKeiNo　サービス契約番号。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void upDateSvkeiExcCtrl(String svcKeiNo) throws Exception { // サービス契約排他制御の最終更新年月日時分秒の更新を行います。 JBSbatCommonDBInterface paramMap = new JBSbatCommonDBInterface(); JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface(); // サービス契約番号を設定 whereMap.setValue(JBSbatKK_T_SVKEI_EXC_CTRL.SVC_KEI_NO, svcKeiNo); // 最終更新年月日時分秒を更新。 paramMap.setValue(JBSbatKK_T_SVKEI_EXC_CTRL.LAST_UPD_DTM, JBSbatDateUtil.getSystemDateTimeStamp()); db_KK_T_SVKEI_EXC_CTRL.updateByPrimaryKeys(whereMap, paramMap); } }