*
* @author 富士通
*/
public class JBSbatKKTmcpOpAutoDslTrgtChsht extends JBSbatBusinessService
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(割賦契約)*/
private static final String D_TBL_NAME_KK_T_KAP_KEI = "KK_T_KAP_KEI";
/** SQL定義キー(KK_SELECT_011)*/
private static final String KK_T_KAP_KEI_KK_SELECT_011 = "KK_SELECT_011";
/** テーブルアクセスクラス(割賦契約)*/
private JBSbatSQLAccess db_KK_T_KAP_KEI = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/** 保証・補償期間開始日算出基準年月日識別コード（配送完了年月日）*/
private static final String HCPRD_STAD_SNSTSTD_YMD_SCD_HAISO = "1";
/** 保証・補償期間開始日算出基準年月日識別コード（工事案件実施年月日）*/
private static final String HCPRD_STAD_SNSTSTD_YMD_SCD_KOJI = "2";
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
// DBアクセスクラスを生成します
db_KK_T_KAP_KEI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_KAP_KEI);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @param inMap 入力電文
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
String svcChrgStaymd = null;
String svcChrgStaymd1 = null;
String svcChrgStaymd2 = null;
// 運用日付取得
String strOpeDate = commonItem.getOpeDate();
//課金開始日の算出
//(1)保証・補償期間開始日算出基準年月日を基に課金開始日を求める。
String hcprdStadSnststdYmdScd = inMap.getString(JBSbatKKIFM727.HCPRD_STAD_SNSTSTD_YMD_SCD);
String hcprdStadSnststdYmd = inMap.getString(JBSbatKKIFM727.HCPRD_STAD_SNSTSTD_YMD);
//保証・補償期間開始日算出基準年月日識別コードが配送完了年月日の場合
if (HCPRD_STAD_SNSTSTD_YMD_SCD_HAISO.equals(hcprdStadSnststdYmdScd))
{
//課金開始日に保証・補償期間開始日算出基準年月日＋１０日の翌月１日を設定
svcChrgStaymd1 = JPCUtilCommon.addMonth(JPCUtilCommon.addDay(hcprdStadSnststdYmd, 10), 1).substring(0, 6).concat("01");
}
//保証・補償期間開始日算出基準年月日識別コードが工事案件実施年月日の場合
else if (HCPRD_STAD_SNSTSTD_YMD_SCD_KOJI.equals(hcprdStadSnststdYmdScd))
{
//課金開始日に保証・補償期間開始日算出基準年月日の翌月１日を設定
svcChrgStaymd1 = JPCUtilCommon.addMonth(hcprdStadSnststdYmd, 1).substring(0, 6).concat("01");
}
//(2)サービス開始日を基に課金開始日を求める。
String svcStaYmd = inMap.getString(JBSbatKKIFM727.SVC_STA_YMD);
String hktgiMotoKapKeiNo = inMap.getString(JBSbatKKIFM727.HKTGI_MOTO_KAP_KEI_NO);
//割賦引継なしの場合
if (JKKStringUtil.isNullBlank(hktgiMotoKapKeiNo))
{
//入力ファイルのサービス開始日の翌月１日を設定
if (!JKKStringUtil.isNullBlank(svcStaYmd))
{
svcChrgStaymd2 = JPCUtilCommon.addMonth(svcStaYmd, 1).substring(0, 6).concat("01");
}
}
//割賦引継ありの場合
else
{
String kapKeiNo = hktgiMotoKapKeiNo;
boolean hktgiMotoFlg = true;
//引継元が無くなるまで繰り返す
while(hktgiMotoFlg)
{
// 割賦契約テーブルSQL発行用領域作成
JBSbatCommonDBInterface kk_t_kap_kei_map = new JBSbatCommonDBInterface();
JBSbatCommonDBInterface kk_t_kap_kei_dbList = new JBSbatCommonDBInterface();
String hktgiMotoKapKeiNo2 = null;
// 割賦契約に対してSQL実行
kk_t_kap_kei_dbList. setValue(strOpeDate);
kk_t_kap_kei_dbList. setValue(strOpeDate);
kk_t_kap_kei_dbList. setValue(strOpeDate);
kk_t_kap_kei_dbList. setValue(kapKeiNo);
executeKK_T_KAP_KEI_KK_SELECT_011(kk_t_kap_kei_dbList.getList().toArray());
for(kk_t_kap_kei_map = db_KK_T_KAP_KEI.selectNext(); null != kk_t_kap_kei_map; kk_t_kap_kei_map = db_KK_T_KAP_KEI.selectNext())
{
hktgiMotoKapKeiNo2 = kk_t_kap_kei_map.getString("HKTGI_MOTO_KAP_KEI_NO"); // 引継元割賦契約番号
svcStaYmd = kk_t_kap_kei_map.getString("SVC_STA_YMD"); // サービス開始年月日
}
if (JKKStringUtil.isNullBlank(hktgiMotoKapKeiNo2) || (!JKKStringUtil.isNullBlank(hktgiMotoKapKeiNo2) && kapKeiNo.equals(hktgiMotoKapKeiNo2)))
{
hktgiMotoFlg = false;
}
else
{
kapKeiNo = hktgiMotoKapKeiNo2;
}
}
//取得したサービス開始日の翌月１日を設定
if (!JKKStringUtil.isNullBlank(svcStaYmd))
{
svcChrgStaymd2 = JPCUtilCommon.addMonth(svcStaYmd, 1).substring(0, 6).concat("01");
}
}
//(3)タブレット端末の課金開始日を求める。
JBSbatOutputItem outputBean = new JBSbatOutputItem();
if(JKKStringUtil.isNullBlank(svcChrgStaymd1) && JKKStringUtil.isNullBlank(svcChrgStaymd2))
{
return outputBean;
}
if(JKKStringUtil.isNullBlank(svcChrgStaymd2) || (!JKKStringUtil.isNullBlank(svcChrgStaymd1) && svcChrgStaymd1.compareTo(svcChrgStaymd2) >= 0))
{
svcChrgStaymd = svcChrgStaymd1;
}
else
{
svcChrgStaymd = svcChrgStaymd2;
}
if (!JKKStringUtil.isNullBlank(inMap.getString(JBSbatKKIFM727.TMCP_PRD)))
{
//端末補償期間の最終年月日の算出
String lastYmd = JPCUtilCommon.addMonth(strOpeDate, (Integer.parseInt(inMap.getString(JBSbatKKIFM727.TMCP_PRD)) * -1) + 1) ;
//課金開始日 ＜ 端末補償期間の最終年月日の場合ファイル出力を行う。
if(lastYmd.compareTo(svcChrgStaymd) > 0)
{
outputBean.addOutMapList(createOutMap(inMap, svcChrgStaymd));
}
}
return outputBean;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 入力ファイルを出力ファイルに成形します
* @param inMap
* @return JBSbatServiceInterfaceMap
*/
private JBSbatServiceInterfaceMap createOutMap(JBSbatServiceInterfaceMap inMap, String svcChrgStaymd)
{
JBSbatServiceInterfaceMap outMap = new JBSbatServiceInterfaceMap();
//機器オプションサービス契約番号
outMap.set(JBSbatKKIFM593.KKOP_SVC_KEI_NO, inMap.get(JBSbatKKIFM727.KKOP_SVC_KEI_NO) );
//ＳＹＳＩＤ
outMap.set(JBSbatKKIFM593.SYSID, inMap.get(JBSbatKKIFM727.SYSID) );
//機器提供サービス契約番号
outMap.set(JBSbatKKIFM593.KKTK_SVC_KEI_NO, inMap.get(JBSbatKKIFM727.KKTK_SVC_KEI_NO) );
//サービス課金開始年月日
outMap.set(JBSbatKKIFM593.SVC_CHRG_STAYMD, svcChrgStaymd );
//宅内機器型式コード
outMap.set(JBSbatKKIFM593.TAKNKIKI_MODEL_CD, inMap.get(JBSbatKKIFM727.TAKNKIKI_MODEL_CD) );
//機器製造番号
outMap.set(JBSbatKKIFM593.KIKI_SEIZO_NO, inMap.get(JBSbatKKIFM727.KIKI_SEIZO_NO) );
//サービス契約番号
outMap.set(JBSbatKKIFM593.SVC_KEI_NO, inMap.get(JBSbatKKIFM727.SVC_KEI_NO) );
outMap.setOutFlg(true);
return outMap;
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_KK_T_KAP_KEI.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* SQLKEY(KK_SELECT_011)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 運用年月日 * 運用年月日 * 運用年月日 * 割賦契約番号 *
* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeKK_T_KAP_KEI_KK_SELECT_011(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()); // DBアクセスを実行します db_KK_T_KAP_KEI.selectBySqlDefine(paramList, KK_T_KAP_KEI_KK_SELECT_011); } /**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/ }