*
* @author 富士通
*/
public class JBSbatKVDateSetChk extends JBSbatBusinessService
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(サービス契約)*/
private static final String D_TBL_NAME_KK_T_SVC_KEI = "KK_T_SVC_KEI";
/** テーブル(工事案件)*/
private static final String D_TBL_NAME_KU_T_KOJIAK = "KU_T_KOJIAK";
/** テーブル(配送)*/
private static final String D_TBL_NAME_DK_T_HAISO = "DK_T_HAISO";
/** テーブル(コード名称管理)*/
private static final String D_TBL_NAME_ZM_M_CD_NM_KANRI = "ZM_M_CD_NM_KANRI";
/** テーブル(料金プラン)*/
private static final String D_TBL_NAME_KK_M_PPLAN = "KK_M_PPLAN";
/** テーブル(サービス契約内訳)*/
private static final String D_TBL_NAME_KK_T_SVC_KEI_UCWK = "KK_T_SVC_KEI_UCWK";
/** テーブル(番ポ工事)*/
private static final String D_TBL_NAME_TU_T_BMP_KOJI = "TU_T_BMP_KOJI";
/** テーブル(機器提供サービス契約)*/
private static final String D_TBL_NAME_KK_T_KKTK_SVC_KEI = "KK_T_KKTK_SVC_KEI";
/** テーブル(回線対象サービス契約)*/
private static final String D_TBL_NAME_KK_T_KAISEN_TG_SVKEI = "KK_T_KAISEN_TG_SVKEI";
/** SQL定義キー(KV_SELECT_013)*/
private static final String KK_T_SVC_KEI_KV_SELECT_013 = "KV_SELECT_013";
/** SQL定義キー(KV_SELECT_014)*/
private static final String KK_T_SVC_KEI_KV_SELECT_014 = "KV_SELECT_014";
/** SQL定義キー(KV_SELECT_022)*/
private static final String KK_T_SVC_KEI_KV_SELECT_022 = "KV_SELECT_022";
/** SQL定義キー(KV_SELECT_015)*/
private static final String KK_T_SVC_KEI_KV_SELECT_016 = "KV_SELECT_016";
/** SQL定義キー(KV_SELECT_002)*/
private static final String KU_T_KOJIAK_KV_SELECT_002 = "KV_SELECT_002";
/** SQL定義キー(KV_SELECT_003)*/
private static final String DK_T_HAISO_KV_SELECT_003 = "KV_SELECT_003";
/** SQL定義キー(KV_SELECT_001)*/
private static final String ZM_M_CD_NM_KANRI_KV_SELECT_001 = "KV_SELECT_001";
/** SQL定義キー(KV_SELECT_001)*/
private static final String KK_M_PPLAN_KV_SELECT_001 = "KV_SELECT_001";
/** SQL定義キー(KV_SELECT_009)*/
private static final String KK_T_SVC_KEI_UCWK_KV_SELECT_012 = "KV_SELECT_012";
/** SQL定義キー(KV_SELECT_001)*/
private static final String TU_T_BMP_KOJI_KV_SELECT_001 = "KV_SELECT_001";
/** SQL定義キー(KV_SELECT_007)*/
private static final String KK_T_KKTK_SVC_KEI_KV_SELECT_007 = "KV_SELECT_007";
/** SQL定義キー(KV_SELECT_004)*/
private static final String KK_T_KAISEN_TG_SVKEI_KV_SELECT_004 = "KV_SELECT_004";
/** テーブルアクセスクラス(回線対象サービス契約)*/
private JBSbatSQLAccess db_KK_T_KAISEN_TG_SVKEI = null;
/** テーブルアクセスクラス(サービス契約)*/
private JBSbatSQLAccess db_KK_T_SVC_KEI = null;
/** テーブルアクセスクラス(工事案件)*/
private JBSbatSQLAccess db_KU_T_KOJIAK = null;
/** テーブルアクセスクラス(配送)*/
private JBSbatSQLAccess db_DK_T_HAISO = null;
/** テーブルアクセスクラス(コード名称管理)*/
private JBSbatSQLAccess db_ZM_M_CD_NM_KANRI = null;
/** テーブルアクセスクラス(料金プラン)*/
private JBSbatSQLAccess db_KK_M_PPLAN = null;
/** テーブルアクセスクラス(サービス契約内訳)*/
private JBSbatSQLAccess db_KK_T_SVC_KEI_UCWK = null;
/** テーブルアクセスクラス(番ポ工事)*/
private JBSbatSQLAccess db_TU_T_BMP_KOJI = null;
/** テーブルアクセスクラス(機器提供サービス契約)*/
private JBSbatSQLAccess db_KK_T_KKTK_SVC_KEI = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/** 調査対象 */
String mode = "";
/** 例外発生フラグ */
boolean isException;
/** コード種別コード(工事案件ステータス) */
private static final String CD_KOJIAK_STAT = "CD00474";
/** コード種別コード(宅内機器種別コード) */
private static final String CD_TAKNKIKI_SBT_CD = "CD01262";
/** 工事案件ステータス(工事完了済) */
private static final String KOJI_FIN_ZUMI = "200";
/** サービス契約ステータス(照査済) */
private static final String SHOSA_ZUMI = "020";
/** 調査対象一覧出力指定(調査対象のみ) */
private static final String CHOSA_TG_DIV_CHOSA_TG_ONLY = "1";
/** 調査対象一覧出力指定(全件) */
private static final String CHOSA_TG_DIV_ALL = "2";
/** 調査対象区分(調査対象) */
private static final String CHOSA_TG_DATA = "1";
/** 調査対象区分(正常) */
private static final String NORMAL_DATA = "2";
/** 調査対象区分(ＤＢ不整合) */
private static final String DB_FUSEIGO_DATA = "4";
/** 調査対象区分(例外) */
private static final String EXCEPTION_DATA = "9";
/** 調査対象区分名称(調査対象) */
private static final String CHOSA_TG_DIV_CHOSA_TG = "調査対象";
/** 調査対象区分名称(正常) */
private static final String CHOSA_TG_DIV_NORMAL = "正常";
/** 調査対象区分名称(ＤＢ不整合) */
private static final String CHOSA_TG_DB_FUSEIGO = "ＤＢ不整合";
/** 調査対象区分名称(例外) */
private static final String CHOSA_TG_DIV_EXCEPTION = "例外";
/** 不整合DB名 */
private String FUSEIGO_DB_NAME = "";
/** 初回読込フラグ */
private boolean firstFlg = true;
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
String[] freeItemArray = commonItem.getFreeItem().split("@");
// バッチ運用日付を取得
// this.opeDate = commonItem.getOpeDate();
this.opeDate = freeItemArray[1];
// 調査対象一覧への出力指定を取得
// mode = commonItem.getFreeItem();
mode = freeItemArray[0];
// DBアクセスクラスを生成します
db_KK_T_SVC_KEI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_SVC_KEI);
db_KU_T_KOJIAK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KU_T_KOJIAK);
db_DK_T_HAISO = new JBSbatSQLAccess(commonItem, D_TBL_NAME_DK_T_HAISO);
db_ZM_M_CD_NM_KANRI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_ZM_M_CD_NM_KANRI);
db_KK_M_PPLAN = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_M_PPLAN);
db_KK_T_SVC_KEI_UCWK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_SVC_KEI_UCWK);
db_KK_T_KKTK_SVC_KEI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_KKTK_SVC_KEI);
db_TU_T_BMP_KOJI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_TU_T_BMP_KOJI);
db_KK_T_KAISEN_TG_SVKEI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_KAISEN_TG_SVKEI);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute() throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
try{
JBSbatOutputItem editBean = new JBSbatOutputItem();
//出力値編集
if(firstFlg){
setHeader(editBean);
firstFlg = false;
}
// 工事完了チェックを行う
editKojiFinChkData(editBean);
// 配送完了チェックを行う
editHaisoFinChkData(editBean);
// 配送完了(電話)のチェック
editHaisoFinChkDataTel(editBean);
// 照査済チェックを行う
editShosaZumiChkData(editBean);
// 編集したBeanを返却する
return editBean;
}catch(Exception e)
{
super.logPrint.printBusinessErrorLog("EKKB0960AI", new String[]{
"例外発生：" + e});
return null;
}
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_KK_T_SVC_KEI.close();
db_KU_T_KOJIAK.close();
db_DK_T_HAISO.close();
db_ZM_M_CD_NM_KANRI.close();
db_KK_M_PPLAN.close();
db_KK_T_SVC_KEI_UCWK.close();
db_TU_T_BMP_KOJI.close();
db_KK_T_KKTK_SVC_KEI.close();
db_KK_T_KAISEN_TG_SVKEI.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* SQLKEY(KV_SELECT_013)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * バッチ運用日付 * バッチ運用日付 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKK_T_SVC_KEI_KV_SELECT_013(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_KK_T_SVC_KEI.selectBySqlDefine(paramList, KK_T_SVC_KEI_KV_SELECT_013);
}
/**
* SQLKEY(KV_SELECT_014)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * バッチ運用日付 * バッチ運用日付 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKK_T_SVC_KEI_KV_SELECT_014(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
paramList.setValue(param[1].toString());
// DBアクセスを実行します
db_KK_T_SVC_KEI.selectBySqlDefine(paramList, KK_T_SVC_KEI_KV_SELECT_014);
}
/**
* SQLKEY(KV_SELECT_015)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * バッチ運用日付 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKK_T_SVC_KEI_KV_SELECT_015(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
// DBアクセスを実行します
db_KK_T_SVC_KEI.selectBySqlDefine(paramList, KK_T_SVC_KEI_KV_SELECT_016);
}
/**
* SQLKEY(KV_SELECT_002)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * サービス契約番号 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKU_T_KOJIAK_KV_SELECT_002(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
// DBアクセスを実行します
db_KU_T_KOJIAK.selectBySqlDefine(paramList, KU_T_KOJIAK_KV_SELECT_002);
}
/**
* SQLKEY(KV_SELECT_003)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 機器提供サービス契約番号 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeDK_T_HAISO_KV_SELECT_003(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
// DBアクセスを実行します
db_DK_T_HAISO.selectBySqlDefine(paramList, DK_T_HAISO_KV_SELECT_003);
}
/**
* SQLKEY(KV_SELECT_001)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * コード種別コード * コード区分 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeZM_M_CD_NM_KANRI_KV_SELECT_001(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_ZM_M_CD_NM_KANRI.selectBySqlDefine(paramList, ZM_M_CD_NM_KANRI_KV_SELECT_001);
}
/**
* SQLKEY(KV_SELECT_001)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * 料金コースコード * 料金プランコード *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKK_M_PPLAN_KV_SELECT_001(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
paramList.setValue(param[1].toString());
// DBアクセスを実行します
db_KK_M_PPLAN.selectBySqlDefine(paramList, KK_M_PPLAN_KV_SELECT_001);
}
/**
* SQLKEY(KV_SELECT_022)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * バッチ運用日付 * バッチ運用日付 *
* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeKK_T_SVC_KEI_KV_SELECT_022(Object[] param) throws Exception { // バイント変数のリストを生成します JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(param[0].toString()); paramList.setValue(param[1].toString()); // DBアクセスを実行します db_KK_T_SVC_KEI.selectBySqlDefine(paramList, KK_T_SVC_KEI_KV_SELECT_022); } //回線対象サービス契約 サービス契約回線内訳 検索 private void executeKK_T_KAISEN_TG_SVKEI_KV_SELECT_004(Object[] param) throws Exception { // バイント変数のリストを生成します JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface(); paramList.setValue(param[0].toString()); paramList.setValue(param[1].toString()); // DBアクセスを実行します db_KK_T_KAISEN_TG_SVKEI.selectBySqlDefine(paramList, KK_T_KAISEN_TG_SVKEI_KV_SELECT_004); } /**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/ /** * アウトプットファイルのヘッダー部設定 * アウトプットファイルのヘッダー部を設定する * @param JBSbatOutputItem outputItem 出力共通電文クラス * @throws Exception */ private void setHeader(JBSbatOutputItem outputItem) throws Exception{ // 出力値編集 JBSbatServiceInterfaceMap outMap = new JBSbatServiceInterfaceMap(); outMap.setString(JBSbatKVIFM009.SYSID,"ＳＹＳＩＤ"); outMap.setString(JBSbatKVIFM009.SVC_KEI_NO,"サービス契約番号"); outMap.setString(JBSbatKVIFM009.SVC_KEI_UCWK_NO,"サービス契約内訳番号"); outMap.setString(JBSbatKVIFM009.PPLAN_CD,"料金プランコード"); outMap.setString(JBSbatKVIFM009.PPLAN_CD_NM,"料金プランコード名称"); outMap.setString(JBSbatKVIFM009.SHOSA_YMD,"照査年月日"); outMap.setString(JBSbatKVIFM009.CNC_YMD,"締結年月日"); outMap.setString(JBSbatKVIFM009.KOJIAK_NO,"工事案件番号"); outMap.setString(JBSbatKVIFM009.KOJIAK_STAT,"工事案件ステータス"); outMap.setString(JBSbatKVIFM009.KOJIAK_STAT_NM,"工事案件ステータス名称"); outMap.setString(JBSbatKVIFM009.KOJIAK_JSSI_YMD,"工事案件実施年月日"); outMap.setString(JBSbatKVIFM009.KOJIAK_FIN_DTM,"工事案件完了年月日時分秒"); outMap.setString(JBSbatKVIFM009.HAISO_NO,"配送番号"); outMap.setString(JBSbatKVIFM009.KKTK_SVC_KEI_NO,"機器提供サービス契約番号"); outMap.setString(JBSbatKVIFM009.HAISO_FIN_YMD,"配送完了年月日"); outMap.setString(JBSbatKVIFM009.TAKNKIKI_SBT_CD,"宅内機器種別コード"); outMap.setString(JBSbatKVIFM009.TAKNKIKI_SBT_CD_NM,"宅内機器種別コード名称"); outMap.setString(JBSbatKVIFM009.CHOSA_TG_DIV,"調査対象区分"); outMap.setString(JBSbatKVIFM009.CHOSA_TG_DIV_NM,"調査対象区分名称"); outMap.setOutFlg(true); outputItem.addOutMapList(outMap); } /** *
* 工事完了チェックと出力ファイルの編集を行う。 *
* @param editBean 編集Bean * @throws Exception 例外全般 */ private void editKojiFinChkData( JBSbatOutputItem editBean ) throws Exception { JBSbatServiceInterfaceMap outMap = new JBSbatServiceInterfaceMap(); JBSbatCommonDBInterface svcKeiData = new JBSbatCommonDBInterface(); JBSbatCommonDBInterface kojiFinChk = new JBSbatCommonDBInterface(); String[] paramList = {opeDate, opeDate, opeDate}; // 工事案件ステータスを取得するためにサービス契約（またはサービス契約内訳）からデータを取得する。 executeKK_T_SVC_KEI_KV_SELECT_013(paramList); svcKeiData = db_KK_T_SVC_KEI.selectNext(); // 抽出対象となったレコード数分、処理を繰り返す while ( svcKeiData != null ) { FUSEIGO_DB_NAME = ""; // 工事完了チェック boolean isChkErr = false; // DB不整合用フラグ boolean isDbFuseigo = false; // サービス契約番号をパラメータに設定する String[] svcParam = {svcKeiData.getString(JBSbatKK_T_SVC_KEI.SVC_KEI_NO)}; // SQL定義キー(KV_SELECT_002)を実行する executeKU_T_KOJIAK_KV_SELECT_002(svcParam); // 実行結果を取得 kojiFinChk = db_KU_T_KOJIAK.selectNext(); // サービス契約番号に該当する工事案件スキーマが取得できない場合はDB不整合 if ( kojiFinChk == null ) { commonItem.getLogPrint().printDebugLog( "DB不整合 工事案件なし サービス契約番号:" + svcKeiData.getString(JBSbatKVIFM009.SVC_KEI_NO)); isChkErr = true; isDbFuseigo = true; FUSEIGO_DB_NAME = " 工事案件"; outMap = editKVIFM009(svcKeiData, kojiFinChk, isChkErr, isDbFuseigo); editBean.addOutMapList(outMap); } else { // 対象となったサービス契約を基に工事案件を取得する while ( kojiFinChk != null ) { // 調査対象一覧への出力指定が"1：調査対象のみ"の場合 if ( CHOSA_TG_DIV_CHOSA_TG_ONLY.equals(mode) ) { // 調査対象レコードの編集（工事案件ステータスが"工事完了済"の場合） if ( KOJI_FIN_ZUMI.equals(kojiFinChk.getString(JBSbatKU_T_KOJIAK.KOJIAK_STAT)) ) { commonItem.getLogPrint().printDebugLog("工事案件ステータス[工事完了済] " + svcKeiData.getString(JBSbatKK_T_SVC_KEI.SVC_KEI_NO)); isChkErr = true; // 工事完了チェック用の編集 outMap = editKVIFM009(svcKeiData, kojiFinChk, isChkErr, isDbFuseigo); editBean.addOutMapList(outMap); // 出力対象外（正常データ） } else { // 次のレコードを読み込む kojiFinChk = db_KU_T_KOJIAK.selectNext(); continue; } // 調査対象一覧への出力指定が"2：全件"の場合 } else if ( CHOSA_TG_DIV_ALL.equals(mode) ) { if ( KOJI_FIN_ZUMI.equals(kojiFinChk.getString(JBSbatKU_T_KOJIAK.KOJIAK_STAT)) ) { commonItem.getLogPrint().printDebugLog("工事案件ステータス[工事完了済] " + svcKeiData.getString(JBSbatKK_T_SVC_KEI.SVC_KEI_NO)); isChkErr = true; } else { isChkErr = false; } // 工事完了チェック用の編集 outMap = editKVIFM009(svcKeiData, kojiFinChk, isChkErr, isDbFuseigo); editBean.addOutMapList(outMap); } // 次のレコードを読み込む kojiFinChk = db_KU_T_KOJIAK.selectNext(); } } // サービス契約の次のレコードを読み込む svcKeiData = db_KK_T_SVC_KEI.selectNext(); } } /** ** 配送完了チェックと出力ファイルの編集を行う。 *
* @param editBean 編集Bean * @throws Exception 例外全般 */ private void editHaisoFinChkData( JBSbatOutputItem editBean ) throws Exception { JBSbatServiceInterfaceMap outMap = new JBSbatServiceInterfaceMap(); JBSbatCommonDBInterface kktkSvcKeiData = new JBSbatCommonDBInterface(); JBSbatCommonDBInterface haisoFinChk = new JBSbatCommonDBInterface(); String[] paramList2 = {opeDate, opeDate}; executeKK_T_SVC_KEI_KV_SELECT_014(paramList2); kktkSvcKeiData = db_KK_T_SVC_KEI.selectNext(); // 抽出対象となったレコード数分、処理を繰り返す while ( kktkSvcKeiData != null ) { FUSEIGO_DB_NAME = ""; // 配送完了チェック boolean isChkErr = false; // DB不整合用フラグ boolean isDbFuseigo = false; String[] kktkSvcParam = {kktkSvcKeiData.getString(JBSbatKK_T_KKTK_SVC_KEI.KKTK_SVC_KEI_NO)}; // SQL定義キー(KV_SELECT_003)を実行する executeDK_T_HAISO_KV_SELECT_003(kktkSvcParam); // 実行結果を取得 haisoFinChk = db_DK_T_HAISO.selectNext(); // 機器提供サービス契約番号に該当する配送スキーマが取得できない場合はDB不整合 if ( haisoFinChk == null ) { commonItem.getLogPrint().printDebugLog( "DB不整合 配送なし 機器提供サービス契約番号:" + kktkSvcKeiData.getString(JBSbatKK_T_KKTK_SVC_KEI.KKTK_SVC_KEI_NO) + " サービス契約番号:" + kktkSvcKeiData.getString(JBSbatKVIFM009.SVC_KEI_NO)); isChkErr = true; isDbFuseigo = true; FUSEIGO_DB_NAME = " 配送"; outMap = editKVIFM009(kktkSvcKeiData, haisoFinChk, isChkErr, isDbFuseigo); editBean.addOutMapList(outMap); } else { while ( haisoFinChk != null ) { // 調査対象一覧への出力指定が"1：調査対象のみ"の場合 if ( CHOSA_TG_DIV_CHOSA_TG_ONLY.equals(mode) ) { // 調査対象レコードの編集（配送完了年月日が設定されている場合） if ( !isNullBlank(haisoFinChk.getString(JBSbatDK_T_HAISO.HAISO_FIN_YMD)) ) { commonItem.getLogPrint().printDebugLog("配送完了年月日が設定あり" + haisoFinChk.getString(JBSbatDK_T_HAISO.HAISO_FIN_YMD) + " " + kktkSvcKeiData.getString(JBSbatKK_T_SVC_KEI.SVC_KEI_NO)); isChkErr = true; // 配送完了チェック用の編集 outMap = editKVIFM009(kktkSvcKeiData, haisoFinChk, isChkErr, isDbFuseigo); editBean.addOutMapList(outMap); // 出力対象外（正常データ） } else { // 次のレコードを読み込む haisoFinChk = db_DK_T_HAISO.selectNext(); continue; } // 調査対象一覧への出力指定が"2：全件"の場合 } else if ( CHOSA_TG_DIV_ALL.equals(mode) ) { // 調査対象レコードの編集（配送完了年月日が設定されている場合） if ( haisoFinChk.getString(JBSbatDK_T_HAISO.HAISO_FIN_YMD) != null ) { commonItem.getLogPrint().printDebugLog("配送完了年月日が設定あり" + haisoFinChk.getString(JBSbatDK_T_HAISO.HAISO_FIN_YMD) + " " + kktkSvcKeiData.getString(JBSbatKK_T_SVC_KEI.SVC_KEI_NO)); isChkErr = true; } else { isChkErr = false; } // 配送完了チェック用の編集 outMap = editKVIFM009(kktkSvcKeiData, haisoFinChk, isChkErr, isDbFuseigo); // 出力共通電文に入出力インターフェースを設定する。 editBean.addOutMapList(outMap); } // 次のレコードを読み込む haisoFinChk = db_DK_T_HAISO.selectNext(); } } // 機器提供サービス契約の次のレコードを読み込む kktkSvcKeiData = db_KK_T_SVC_KEI.selectNext(); } } /** ** 電話の配送完了チェックと出力ファイルの編集を行う。 *
* @param editBean 編集Bean * @throws Exception 例外全般 */ private void editHaisoFinChkDataTel( JBSbatOutputItem editBean ) throws Exception { JBSbatServiceInterfaceMap outMap = new JBSbatServiceInterfaceMap(); //機器提供サービス契約は検索しない？ JBSbatCommonDBInterface kktkSvcKeiData = new JBSbatCommonDBInterface(); JBSbatCommonDBInterface haisoFinChk = new JBSbatCommonDBInterface(); String[] paramList2 = {opeDate, opeDate}; executeKK_T_SVC_KEI_KV_SELECT_022(paramList2); kktkSvcKeiData = db_KK_T_SVC_KEI.selectNext(); // 抽出対象となったレコード数分、処理を繰り返す while ( kktkSvcKeiData != null ) { FUSEIGO_DB_NAME = ""; // 配送完了チェック boolean isChkErr = false; // DB不整合用フラグ boolean isDbFuseigo = false; //サービス契約番号 String kktkSvck = kktkSvcKeiData.getString(JBSbatKK_T_SVC_KEI.SVC_KEI_NO); ArrayList* 照査済チェックと出力ファイルの編集を行う。 *
* @param editBean 編集Bean * @throws Exception 例外全般 */ private void editShosaZumiChkData( JBSbatOutputItem editBean ) throws Exception { JBSbatServiceInterfaceMap outMap = new JBSbatServiceInterfaceMap(); JBSbatCommonDBInterface shosaSvcKeiData = new JBSbatCommonDBInterface(); String[] paramList3 = {opeDate}; executeKK_T_SVC_KEI_KV_SELECT_015(paramList3); shosaSvcKeiData = db_KK_T_SVC_KEI.selectNext(); // 抽出対象となったレコード数分、処理を繰り返す while ( shosaSvcKeiData != null ) { // サービス契約ステータスが照査済の場合、調査対象一覧 if (SHOSA_ZUMI.equals(shosaSvcKeiData.getString(JBSbatKK_T_SVC_KEI.SVC_KEI_STAT))) { outMap = editKVIFM009(shosaSvcKeiData, null, true, false); editBean.addOutMapList(outMap); } // 次のレコードを読み込む shosaSvcKeiData = db_KK_T_SVC_KEI.selectNext(); } } /** ** 調査対象一覧の項目編集を行う。 *
* * @param svcKeiData サービス契約から取得したデータ * @param finChkData 工事完了チェックまたは配送完了チェック対象データ * @param isChkErr 調査対象の場合：true、正常データの場合：false * @param isDbFuseigo DB不整合の場合：true、それ以外の場合：false * @return outputBean 編集済みのBean * @throws Exception 例外全般 */ private JBSbatServiceInterfaceMap editKVIFM009(JBSbatCommonDBInterface svcKeiData, JBSbatCommonDBInterface finChkData, boolean isChkErr, boolean isDbFuseigo) throws Exception { //入出力インターフェースオブジェクトを生成 JBSbatServiceInterfaceMap outmap = new JBSbatServiceInterfaceMap(); // 工事案件ステータス名称 String kojiakStatNm = ""; // 宅内機器種別コード名称 String taknkikiSbtCdNm = ""; // 項目を設定 // SYSID if ( !isNullBlank((svcKeiData.getString(JBSbatKVIFM009.SYSID))) ) { outmap.set(JBSbatKVIFM009.SYSID, svcKeiData.getString(JBSbatKVIFM009.SYSID)); } // サービス契約番号 if ( !isNullBlank(svcKeiData.getString(JBSbatKVIFM009.SVC_KEI_NO)) ) { outmap.set(JBSbatKVIFM009.SVC_KEI_NO, svcKeiData.getString(JBSbatKVIFM009.SVC_KEI_NO)); } // サービス契約内訳番号 if ( !isNullBlank(svcKeiData.getString(JBSbatKVIFM009.SVC_KEI_UCWK_NO)) ) { outmap.set(JBSbatKVIFM009.SVC_KEI_UCWK_NO, svcKeiData.getString(JBSbatKVIFM009.SVC_KEI_UCWK_NO)); } //料金グループCD電話の場合は必ずセット(電話のみセットされている)↑と異なる 要確認 if ( !isNullBlank(svcKeiData.getString("svcKUchwkNoTel"))) { outmap.set(JBSbatKVIFM009.SVC_KEI_UCWK_NO, svcKeiData.getString("svcKUchwkNoTel")); } // 料金プランコード、料金プランコード名称 if ( !isNullBlank(svcKeiData.getString(JBSbatKVIFM009.PPLAN_CD)) ) { // 料金グループコード outmap.set(JBSbatKVIFM009.PPLAN_CD, svcKeiData.getString(JBSbatKVIFM009.PPLAN_CD)); // 料金プランコード名称 String pplanCdNm = getPplanCdName(svcKeiData.getString(JBSbatKK_T_SVC_KEI.PCRS_CD), svcKeiData.getString(JBSbatKK_T_SVC_KEI.PPLAN_CD)); outmap.set(JBSbatKVIFM009.PPLAN_CD_NM, pplanCdNm); } // 照査年月日 if ( !isNullBlank(svcKeiData.getString(JBSbatKVIFM009.SHOSA_YMD)) ) { outmap.set(JBSbatKVIFM009.SHOSA_YMD, svcKeiData.getString(JBSbatKVIFM009.SHOSA_YMD)); } // 締結年月日 if ( !isNullBlank(svcKeiData.getString(JBSbatKVIFM009.CNC_YMD)) ) { outmap.set(JBSbatKVIFM009.CNC_YMD, svcKeiData.getString(JBSbatKVIFM009.CNC_YMD)); } // 機器提供サービス番号 if ( !isNullBlank(svcKeiData.getString(JBSbatKVIFM009.KKTK_SVC_KEI_NO)) ) { outmap.set(JBSbatKVIFM009.KKTK_SVC_KEI_NO, svcKeiData.getString(JBSbatKVIFM009.KKTK_SVC_KEI_NO)); } // 宅内機器種別コード、宅内機器種別コード名称 if ( !isNullBlank(svcKeiData.getString(JBSbatKVIFM009.TAKNKIKI_SBT_CD)) ) { // 宅内機器種別コード outmap.set(JBSbatKVIFM009.TAKNKIKI_SBT_CD, svcKeiData.getString(JBSbatKVIFM009.TAKNKIKI_SBT_CD)); // 宅内機器種別コード名称 taknkikiSbtCdNm = getCdName(CD_TAKNKIKI_SBT_CD, svcKeiData.getString(JBSbatKVIFM009.TAKNKIKI_SBT_CD)); outmap.set(JBSbatKVIFM009.TAKNKIKI_SBT_CD_NM, taknkikiSbtCdNm); } // DB不整合以外、または照査済チェック以外の場合 if ( finChkData != null ) { // 工事案件番号 if ( !isNullBlank(finChkData.getString(JBSbatKVIFM009.KOJIAK_NO)) ) { outmap.set(JBSbatKVIFM009.KOJIAK_NO, finChkData.getString(JBSbatKVIFM009.KOJIAK_NO)); } // 工事案件ステータス、工事案件ステータス名称 if ( !isNullBlank(finChkData.getString(JBSbatKVIFM009.KOJIAK_STAT)) ) { // 工事案件ステータス outmap.set(JBSbatKVIFM009.KOJIAK_STAT, finChkData.getString(JBSbatKVIFM009.KOJIAK_STAT)); // 工事案件ステータス名称 kojiakStatNm = getCdName(CD_KOJIAK_STAT, finChkData.getString(JBSbatKVIFM009.KOJIAK_STAT)); outmap.set(JBSbatKVIFM009.KOJIAK_STAT_NM, kojiakStatNm); } // 工事案件実施年月日 if ( !isNullBlank(finChkData.getString(JBSbatKVIFM009.KOJIAK_JSSI_YMD)) ) { outmap.set(JBSbatKVIFM009.KOJIAK_JSSI_YMD, finChkData.getString(JBSbatKVIFM009.KOJIAK_JSSI_YMD)); } // 工事案件完了年月日時分秒 if ( !isNullBlank(finChkData.getString(JBSbatKVIFM009.KOJIAK_FIN_DTM)) ) { outmap.set(JBSbatKVIFM009.KOJIAK_FIN_DTM, finChkData.getString(JBSbatKVIFM009.KOJIAK_FIN_DTM)); } // 配送番号 if ( !isNullBlank(finChkData.getString(JBSbatKVIFM009.HAISO_NO)) ) { outmap.set(JBSbatKVIFM009.HAISO_NO, finChkData.getString(JBSbatKVIFM009.HAISO_NO)); } if ( !isNullBlank(finChkData.getString(JBSbatKVIFM009.HAISO_FIN_YMD)) ) { // 配送完了年月日 outmap.set(JBSbatKVIFM009.HAISO_FIN_YMD, finChkData.getString(JBSbatKVIFM009.HAISO_FIN_YMD)); } } // 調査対象区分、調査対象区分名称 // チェックエラーの場合 if ( isChkErr ) { // ＤＢ不整合 if (isDbFuseigo) { // 調査対象区分 outmap.set(JBSbatKVIFM009.CHOSA_TG_DIV, DB_FUSEIGO_DATA); // 調査対象区分名称 outmap.set(JBSbatKVIFM009.CHOSA_TG_DIV_NM, CHOSA_TG_DB_FUSEIGO + FUSEIGO_DB_NAME); // 調査対象データ } else { // 調査対象区分 outmap.set(JBSbatKVIFM009.CHOSA_TG_DIV, CHOSA_TG_DATA); // 調査対象区分名称 outmap.set(JBSbatKVIFM009.CHOSA_TG_DIV_NM, CHOSA_TG_DIV_CHOSA_TG); } // 正常の場合 } else { // 調査対象区分 outmap.set(JBSbatKVIFM009.CHOSA_TG_DIV, NORMAL_DATA); // 調査対象区分名称 outmap.set(JBSbatKVIFM009.CHOSA_TG_DIV_NM, CHOSA_TG_DIV_NORMAL); } // 例外が発生した場合、識別が可能なように調査対象区分を"9"、調査対象区分名称を"例外"で上書く if ( isException ) { // 調査対象区分 outmap.set(JBSbatKVIFM009.CHOSA_TG_DIV, EXCEPTION_DATA); // 調査対象区分名称 outmap.set(JBSbatKVIFM009.CHOSA_TG_DIV_NM, CHOSA_TG_DIV_EXCEPTION); } outmap.setOutFlg(true); return outmap; } /** ** コード名称管理マスタからコード名称を取得する。 *
* @param cdSbtCd コード種別コード * @param cdDiv コード区分 * @return cdName コード名称 * @exception 例外全般 */ private String getCdName(String cdSbtCd, String cdDiv) throws Exception { isException = false; try { JBSbatCommonDBInterface cdNmKanri = new JBSbatCommonDBInterface(); String cdName = ""; // SQLを実行するための引数(コード種別コード、コード区分)を設定 String[] paramList = {cdSbtCd, cdDiv, this.opeDate, this.opeDate}; // SQLを実行する executeZM_M_CD_NM_KANRI_KV_SELECT_001(paramList); cdNmKanri = db_ZM_M_CD_NM_KANRI.selectNext(); // 取得してきたコード名称を設定する。 if (cdNmKanri != null) { cdName = cdNmKanri.getString("CD_DIV_NM"); } return cdName; // 例外が発生した場合 } catch (Exception e) { isException = true; return ""; } } /** ** 料金プランコード名称を取得する。 *
* @param pcrsCd 料金コースコード * @param pplanCd 料金プランコード * @return pplanCdNm 料金プランコード名 * @exception 例外全般 */ private String getPplanCdName(String pcrsCd, String pplanCd) throws Exception { isException = false; try { JBSbatCommonDBInterface pplan = new JBSbatCommonDBInterface(); String pplanCdNm = ""; // SQLを実行するための引数(料金グループコード、バッチ運用日付)を設定 String[] paramList = {pcrsCd, pplanCd}; // SQLを実行する executeKK_M_PPLAN_KV_SELECT_001(paramList); pplan = db_KK_M_PPLAN.selectNext(); // 取得してきた料金プラン名称を設定する。 if (pplan != null) { pplanCdNm = pplan.getString("PPLAN_NM"); } return pplanCdNm; // 例外が発生した場合 } catch (Exception e) { isException = true; return ""; } } /** * 番ポ情報取得 * @param svckNo * @return 番ポ有無 * @throws Exception */ private ArrayList
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * サービス契約番号 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKK_T_SVC_KEI_UCWK_KV_SELECT_012(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
// paramList.setValue(param[1].toString());
// DBアクセスを実行します
db_KK_T_SVC_KEI_UCWK.selectBySqlDefine(paramList, KK_T_SVC_KEI_UCWK_KV_SELECT_012);
}
/**
* SQLKEY(KV_SELECT_001)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * サービス契約内訳番号 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeTU_T_BMP_KOJI_KV_SELECT_001(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
// DBアクセスを実行します
db_TU_T_BMP_KOJI.selectBySqlDefine(paramList, TU_T_BMP_KOJI_KV_SELECT_001);
}
// 2014/01/08 [ANK-1578-00-00] 多機能ルーター追加 DEL START
// /**
// * SQLKEY(KV_SELECT_007)でDBアクセスを行います。
// *
// * 処理フロー
// *
// * 1.引数でバイント変数を設定します。// *
// * // * 2.DBアクセスを実行します。
// * // * 3.メソッドの呼び出し方です。
// * 引数: // * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 // * サービス契約番号 // * 運用日 // * 運用日 // *
// * @param param バイント変数の値配列。
// * @throws Exception 業務サービス内で発生した例外全般。
// */
// private void executeKK_T_KKTK_SVC_KEI_KV_SELECT_007(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_KK_T_KKTK_SVC_KEI.selectBySqlDefine(paramList, KK_T_KKTK_SVC_KEI_KV_SELECT_007);
// }
// 2014/01/08 [ANK-1578-00-00] 多機能ルーター追加 DEL END
// 2014/01/08 [ANK-1578-00-00] 多機能ルーター追加 ADD START
/**
* SQLKEY(KV_SELECT_007)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * サービス契約番号 * 運用日 * 運用日 *
* @param param バイント変数の値配列。 * @throws Exception 業務サービス内で発生した例外全般。 */ private void executeKK_T_KKTK_SVC_KEI_KV_SELECT_007(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[0].toString()); paramList.setValue(param[1].toString()); paramList.setValue(param[2].toString()); paramList.setValue(param[1].toString()); paramList.setValue(param[2].toString()); paramList.setValue(param[1].toString()); paramList.setValue(param[2].toString()); // DBアクセスを実行します db_KK_T_KKTK_SVC_KEI.selectBySqlDefine(paramList, KK_T_KKTK_SVC_KEI_KV_SELECT_007); } // 2014/01/08 [ANK-1578-00-00] 多機能ルーター追加 ADD END }