/********************************************************************* * All Rights reserved,Copyright (c) K-Opticom ********************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JBSbatKKHapiekSndAfUpd * ソースファイル名 ：JBSbatKKHapiekSndAfUpd.java * 作成者 ：富士通　 * 作成日 ：2012年08月07日 *＜機能概要＞ *　はぴｅポイント契約送信後更新部品です。 *＜修正履歴＞ * バージョン 修正日 修正者 修正内容 * v4.00.00 2012/08/07 富士通 新規作成 * v9.00.00 2014/07/08 FJ)西面 OM-2014-0002162 サービス開始年月日、サービス終了年月日を設定する。 * v11.00.00 2014/10/11 FJ)寺園 【OM-2014-0002128】【ANK-2306-07-00】はぴe誤ポイント対応 * v11.00.01 2014/12/10 FJ)西面 ST-2014-0000170 審査NG時のはぴeポイント契約ステータス変更 * v29.00.00 2017/01/24 FJ)貝本 【OM-2016-0002257】はぴｅP審査E送信 * v29.00.01 2017/01/26 FJ)貝本 【OM-2016-0002257】はぴｅP審査E送信(無効フラグ更新処理追加) *********************************************************************/ package eo.business.service; import eo.business.common.JBSbatBusinessService; import eo.business.common.JBSbatKKConst; import eo.business.util.file.JBSbatKKIFM245; import eo.business.util.table.JBSbatKK_T_HAPIE_POINT_KEI; import eo.common.util.JKKStringUtil; import eo.framework.item.JBSbatCommonItem; import eo.framework.item.JBSbatServiceInterfaceMap; import eo.framework.item.JBSbatOutputItem; import eo.framework.item.JBSbatCommonDBInterface; import eo.framework.db.JBSbatSQLAccess; /** * (クラスの機能概要)

*
* @author 富士通 */ public class JBSbatKKHapiekSndAfUpd extends JBSbatBusinessService { /**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/ /** テーブル(はぴｅポイント契約)*/ private static final String D_TBL_NAME_KK_T_HAPIE_POINT_KEI = "KK_T_HAPIE_POINT_KEI"; // v11.00.00 2014/10/11 ADD START /** テーブル(はぴeポイント契約審査連携)*/ private static final String D_TBL_NAME_KK_T_HAPIEK_JDG_RNK = "KK_T_HAPIEK_JDG_RNK"; // v11.00.00 2014/10/11 ADD END /** SQL定義キー(KK_UPDATE_003)*/ private static final String KK_T_HAPIE_POINT_KEI_KK_UPDATE_003 = "KK_UPDATE_003"; // v29.00.00 2016/01/24 DEL START // /** SQL定義キー(KK_UPDATE_004)*/ // private static final String KK_T_HAPIE_POINT_KEI_KK_UPDATE_004 = "KK_UPDATE_004"; // v29.00.00 2016/01/24 DEL END // v29.00.01 2016/01/26 ADD START private static final String KK_T_HAPIE_POINT_KEI_KK_UPDATE_004 = "KK_UPDATE_004"; // v29.00.01 2016/01/26 ADD END // v11.00.00 2014/10/11 ADD START /** SQL定義キー(KK_UPDATE_001)*/ private static final String KK_T_HAPIEK_JDG_RNK_KK_UPDATE_001 = "KK_UPDATE_001"; // v11.00.00 2014/10/11 ADD END //v9.00.00 2014/07/08 Add Start /** SQL定義キー(KK_SELECT_010)*/ private static final String KK_T_HAPIE_POINT_KEI_KK_SELECT_010= "KK_SELECT_010"; //v9.00.00 2014/07/08 Add End //v11.00.01 2014/12/10 Add Start /** SQL定義キー(KK_SELECT_015)*/ private static final String KK_T_HAPIE_POINT_KEI_KK_SELECT_015="KK_SELECT_015"; //v11.00.01 2014/12/10 Add End /** テーブルアクセスクラス(はぴｅポイント契約)*/ private JBSbatSQLAccess db_KK_T_HAPIE_POINT_KEI = null; // v11.00.00 2014/10/11 ADD START /** テーブルアクセスクラス(はぴeポイント契約審査連携)*/ private JBSbatSQLAccess db_KK_T_HAPIEK_JDG_RNK = null; // v11.00.00 2014/10/11 ADD END /**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/ //v9.00.00 2014/07/08 Add Start /** 終了年月日の最大値*/ private static final String MAX_END_YMD= "20991231"; //v9.00.00 2014/07/08 Add End /** * 初期処理 * @param JBSbatCommonItem commonItem　バッチ共通パラメータ電文 * @throws Exception */ public void initial(JBSbatCommonItem commonItem) throws Exception { /**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/ /**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/ // 共通パラメータを設定します super.setCommonInfo(commonItem); // DBアクセスクラスを生成します db_KK_T_HAPIE_POINT_KEI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_HAPIE_POINT_KEI); // v11.00.00 2014/10/11 ADD START db_KK_T_HAPIEK_JDG_RNK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_HAPIEK_JDG_RNK); // v11.00.00 2014/10/11 ADD END /**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/ /**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/ } /** * 主処理 * @param inMap　入力電文 * @return JBSbatOutputItem　出力情報 * @throws Exception */ public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception { /**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/ //入力ファイルから"はぴｅポイント契約番号"を取得 String in_hapie_point_kei_no = inMap.getString(JBSbatKKIFM245.HAPIE_POINT_KEI_NO); // v29.00.00 2017/01/24 DEL START // //入力ファイルから"はぴｅ番号"を取得 // String in_hapie_no = inMap.getString(JBSbatKKIFM245.HAPIE_NO); // v29.00.00 2017/01/24 DEL END //v9.00.00 2014/07/08 Add Start //はぴeポイント契約スキーマより、サービス開始年月日を取得する String svc_staymd = getSvcStaYmd(inMap); //サービス終了年月日を取得する String svc_endymd = getSvcEndYmd(svc_staymd); //v9.00.00 2014/07/08 Add End // v6.00.00 2013.12.11 ADD START（審査結果コードの値によって、はぴｅポイント契約ステータスの更新値を分ける） String hapieStat = ""; if(JBSbatKKConst.HAPIEK_SKA_OK.equals(inMap.getString(JBSbatKKIFM245.POINT_KEI_SKEKKA_CD))) { hapieStat = JBSbatKKConst.HAPIE_POINT_KEI_STAT_SVCTK; } else { // v11.00.01 2014/12/10 Mod Start //hapieStat = JBSbatKKConst.HAPIE_POINT_KEI_STAT_UK_ZUMI; hapieStat = getHapieStat(inMap); // v11.00.01 2014/12/10 Mod End } //実行SQL(KK_T_HAPIE_POINT_KEI_KK_UPDATE_003)に引数を設定して実行 // Object[] param1 = {in_hapie_point_kei_no}; // v9.00.00 2014/07/08 Mod Start //Object[] param1 = {hapieStat, in_hapie_point_kei_no}; Object[] param1 = {hapieStat,svc_staymd,svc_endymd,in_hapie_point_kei_no}; // v9.00.00 2014/07/08 Mod End // v6.00.00 2013.12.11 ADD END executeKK_T_HAPIE_POINT_KEI_KK_UPDATE_003(param1); // v29.00.00 2017/01/24 DEL START // //実行SQL(KK_T_HAPIE_POINT_KEI_KK_UPDATE_004)に引数を設定して実行 // Object[] param2 = {in_hapie_no}; // executeKK_T_HAPIE_POINT_KEI_KK_UPDATE_004(param2); // v29.00.00 2017/01/24 DEL END // v29.00.01 2017/01/26 ADD START //実行SQL(KK_T_HAPIE_POINT_KEI_KK_UPDATE_004)に引数を設定して実行 Object[] param2 = {in_hapie_point_kei_no}; executeKK_T_HAPIE_POINT_KEI_KK_UPDATE_004(param2); // v29.00.01 2017/01/26 ADD END // v11.00.00 2014/10/11 ADD START Object[] param3 = {in_hapie_point_kei_no,in_hapie_point_kei_no,in_hapie_point_kei_no}; executeKK_T_HAPIEK_JDG_RNK_KK_UPDATE_001(param3); // v11.00.00 2014/10/11 ADD END return null; /**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/ } /** * 業務サービス終了処理 * @throws Exception */ public void terminal() throws Exception { /**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/ /**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/ // DBアクセスクラスをクローズします db_KK_T_HAPIE_POINT_KEI.close(); /**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/ /**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/ } /**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/ /** * SQLKEY(KK_UPDATE_003)でDBアクセスを行います。
*

* 処理フロー
* 

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

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

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

	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	はぴeポイント契約ステータス
	 *		 	はぴeポイント契約番号
	 *
*

* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeKK_T_HAPIE_POINT_KEI_KK_UPDATE_003(Object[] param) throws Exception { // バイント変数のリストを生成します JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(param[0].toString()); // v6.00.00 2013.12.11 ADD START（バインド変数追加（はぴｅポイント契約ステータス）） paramList.setValue(param[1].toString()); // v6.00.00 2013.12.11 ADD END // v9.00.00 2014/07/08 Add Start paramList.setValue(param[2].toString()); //サービス開始年月日 paramList.setValue(param[3].toString()); //サービス終了年月日 // v9.00.00 2014/07/08 Add End // DBアクセスを実行します db_KK_T_HAPIE_POINT_KEI.executeBySqlDefine(paramList, KK_T_HAPIE_POINT_KEI_KK_UPDATE_003); } // v29.00.00 2017/01/24 DEL START // /** // * SQLKEY(KK_UPDATE_004)でDBアクセスを行います。
// *

// * 処理フロー
// * 

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

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

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

//	 *		引数:
//	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
//	 *		 	はぴe番号
//	 *
// *

// * @param param バイント変数の値配列。 // * @throws Exception 業務サービス内で発生した例外全般。 // */ // private void executeKK_T_HAPIE_POINT_KEI_KK_UPDATE_004(Object[] param) throws Exception // { // // バイント変数のリストを生成します // JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); // paramList.setValue(param[0].toString()); // // // DBアクセスを実行します // db_KK_T_HAPIE_POINT_KEI.executeBySqlDefine(paramList, KK_T_HAPIE_POINT_KEI_KK_UPDATE_004); // } // v29.00.00 2017/01/24 DEL END // v29.00.01 2017/01/26 ADD START /** * SQLKEY(KK_UPDATE_004)でDBアクセスを行います。
*

* 処理フロー
* 

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

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

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

	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	はぴe番号
	 *
*

* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeKK_T_HAPIE_POINT_KEI_KK_UPDATE_004(Object[] param) throws Exception { // バイント変数のリストを生成します JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(param[0].toString()); // DBアクセスを実行します db_KK_T_HAPIE_POINT_KEI.executeBySqlDefine(paramList, KK_T_HAPIE_POINT_KEI_KK_UPDATE_004); } // v29.00.01 2017/01/26 ADD END /**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/ // v11.00.00 2014/10/11 ADD START /** * SQLKEY(KK_UPDATE_001)でDBアクセスを行います。
*

* 処理フロー
* 

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

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

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

	 *		引数:
	 *		param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。
	 *		 	はぴeポイント契約番号
	 *		 	はぴeポイント契約番号
	 *		 	はぴeポイント契約番号
	 *
*

* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeKK_T_HAPIEK_JDG_RNK_KK_UPDATE_001(Object[] param) throws Exception { // バイント変数のリストを生成します JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(param[0].toString()); //はぴeポイント契約番号 paramList.setValue(param[1].toString()); //はぴeポイント契約番号 paramList.setValue(param[2].toString()); //はぴeポイント契約番号 // DBアクセスを実行します db_KK_T_HAPIEK_JDG_RNK.executeBySqlDefine(paramList, KK_T_HAPIEK_JDG_RNK_KK_UPDATE_001); } // v11.00.00 2014/10/11 ADD END //v9.00.00 2014/07/08 Add Start /** * はぴeポイント契約スキーマに、既にサービス開始年月日が設定されているかを判定するため * はぴeポイント契約番号に紐付く、はぴeポイント契約スキーマを検索し * 取得したサービス開始年月日を返却する。 * * @param hapiePointKeiNo 更新対象のはぴeポイント契約番号（KKIFM245より取得) * @return サービス開始年月日 * @throws Exception */ private String getSvcStaYmd (JBSbatServiceInterfaceMap inMap) throws Exception { //DBより取得したサービス開始年月日を格納する String svc_staymd =""; //サービス開始年月日設定有無を判定するため、入力ファイルよりポイント契約審査結果コードを取得する String point_kei_skekka_cd = inMap.getString(JBSbatKKIFM245.POINT_KEI_SKEKKA_CD); //はぴeポイント契約スキーマより、サービス開始年月日を取得するため、KK_SELECT_010を実行する executeKK_T_HAPIE_POINT_KEI_KK_SELECT_010(setHapiePointParam(inMap)); //実行結果より、サービス開始年月日を取得する JBSbatCommonDBInterface dbHapiePointKei = new JBSbatCommonDBInterface(); if(null != (dbHapiePointKei = db_KK_T_HAPIE_POINT_KEI.selectNext())) { //DBより取得したサービス開始年月日を取得する。 String dbSvcStaYmd =dbHapiePointKei.getString(JBSbatKK_T_HAPIE_POINT_KEI.SVC_STAYMD); //取得したサービス開始年月日が、null or 空白以外の時、取得した値を更新用のサービス開始年月日に設定する if(!JKKStringUtil.isNullBlank(dbSvcStaYmd)){ svc_staymd = dbSvcStaYmd; } } //取得したサービス開始年月日を元に、はぴeポイント契約更新用のサービス開始年月日を設定する svc_staymd = checkSvcStaYmd(svc_staymd,point_kei_skekka_cd); return svc_staymd; } /** * はぴeポイント契約更新用のサービス開始年月日を設定するため * サービス開始年月日のチェック、補正を行う * サービス開始年月日 = null and ポイント契約審査結果コード= "00"OKの時、運用日を設定する。 * サービス開始年月日 = 上記以外の時、補正せず返却する（すでに設定されている場合、更新対象としないため）。 * * @param svc_staymd はぴeポイント契約スキーマより取得したサービス開始年月日 * @return 更新用のサービス開始年月日 */ private String checkSvcStaYmd(String svc_staymd,String point_kei_skekka_cd) { //サービス開始年月日がnullかつ、ポイント契約審査結果コードが"00"OKの場合、運用日を設定する。それ以外は、取得した値をそのまま設定 if(JKKStringUtil.isNullBlank(svc_staymd) && JBSbatKKConst.HAPIEK_SKA_OK.equals(point_kei_skekka_cd)){ svc_staymd = super.opeDate; } return svc_staymd; } /** * はぴeポイント契約スキーマより、KK_SELECT_010を利用し * はぴeポイント契約番号に紐付くサービス開始年月日を取得する。 * @param param バイント変数の値配列 * @throws Exception */ private void executeKK_T_HAPIE_POINT_KEI_KK_SELECT_010(Object[] param) throws Exception { // バイント変数のリストを生成します JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(param[0].toString()); // DBアクセスを実行します db_KK_T_HAPIE_POINT_KEI.selectBySqlDefine(paramList, KK_T_HAPIE_POINT_KEI_KK_SELECT_010); } /** * ポイント契約審査結果コードが"00"OKであるかの判定を行う * @param pointKeiSkekkaCd ポイント契約審査結果コード * @return true "00"OK false "01"NG * @throws Exception */ private boolean isSkekkaOk(JBSbatServiceInterfaceMap inMap) throws Exception{ //ポイント契約審査結果判定フラグ（true "00" false "01") boolean judgeSkekkaOk = false; //ポイント契約審査結果コード String pointKeiSkekkaCd = inMap.getString(JBSbatKKIFM245.POINT_KEI_SKEKKA_CD); //ポイント契約審査結果コードが"00"審査OKの時、ポイント契約審査結果判定フラグにtrueを設定する if(JBSbatKKConst.HAPIEK_SKA_OK.equals(pointKeiSkekkaCd)){ judgeSkekkaOk = true; } return judgeSkekkaOk; } /** * KK_SELECT_010のバインド変数を設定する * @param inMap 入力ファイル(KKIFM245) * @return はぴeポイント契約検索用パラメータ * @throws Exception */ private Object[] setHapiePointParam(JBSbatServiceInterfaceMap inMap) throws Exception { //_KK_SELECT_010のバインド変数を設定する String[] param = { inMap.getString(JBSbatKKIFM245.HAPIE_POINT_KEI_NO), //はぴeポイント契約番号 }; return param; } /** * サービス終了年月日の設定を行う * サービス開始日に値が存在する場合、"20991231"（固定値）を設定する * サービス開始日に値が存在しない場合、nullを設定する * @param svc_staymd サービス開始年月日 * @return サービス終了年月日 * @throws Exception */ private String getSvcEndYmd (String svc_staymd) throws Exception { //更新用サービス終了年月日設定用 String svc_endymd = ""; //サービス開始年月日に値が存在する場合、サービス終了年月日に"20991231"（固定値）を設定する if(!JKKStringUtil.isNullBlank(svc_staymd)){ svc_endymd = MAX_END_YMD; } return svc_endymd; } //v9.00.00 2014/07/08 Add End //v11.00.01 2014/12/10 Add Start /** * はぴeポイント契約番号に紐付く、はぴeポイント契約ステータスを取得する * 取得したはぴeポイント契約ステータスを返却する。 * * @param inMap * @return はぴeポイント契約ステータス * @throws Exception */ private String getHapieStat(JBSbatServiceInterfaceMap inMap) throws Exception { String hapiePointStat = ""; //はぴeポイント契約スキーマより、はぴeポイント契約ステータスを取得するため、KK_SELECT_015を実行する executeKK_T_HAPIE_POINT_KEI_KK_SELECT_015(setSelect015Param(inMap)); JBSbatCommonDBInterface dbHapiePointKei = new JBSbatCommonDBInterface(); if(null != (dbHapiePointKei = db_KK_T_HAPIE_POINT_KEI.selectNext())) { //DBより取得したはぴeポイント契約ステータスを取得する。 hapiePointStat =dbHapiePointKei.getString(JBSbatKK_T_HAPIE_POINT_KEI.HAPIE_POINT_KEI_STAT); } return hapiePointStat; } /** * はぴeポイント契約スキーマより、KK_SELECT_015を利用し * はぴeポイント契約番号に紐付くはぴeポイント契約ステータスを取得する。 * @param param バイント変数の値配列 * @throws Exception */ private void executeKK_T_HAPIE_POINT_KEI_KK_SELECT_015(Object[] param) throws Exception { // バイント変数のリストを生成します JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(param[0].toString()); // DBアクセスを実行します db_KK_T_HAPIE_POINT_KEI.selectBySqlDefine(paramList, KK_T_HAPIE_POINT_KEI_KK_SELECT_015); } /** * KK_SELECT_015のバインド変数を設定する * @param inMap 入力ファイル(KKIFM245) * @return はぴeポイント契約検索用パラメータ * @throws Exception */ private Object[] setSelect015Param(JBSbatServiceInterfaceMap inMap) throws Exception { //_KK_SELECT_015のバインド変数を設定する String[] param = { inMap.getString(JBSbatKKIFM245.HAPIE_POINT_KEI_NO), //はぴeポイント契約番号 }; return param; } //v11.00.01 2014/12/10 Add End }