*
* @author 富士通
*/
public class JBSbatWCDlydCSVLinkUpdRsltChk extends JBSbatBusinessService
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(視聴制御ＨＵＬＦＴ送信実績)*/
private static final String D_TBL_NAME_WC_T_WC_HULFT_SDJSK = "WC_T_WC_HULFT_SDJSK";
/** SQL定義キー(WC_SELECT_001)*/
private static final String WC_T_WC_HULFT_SDJSK_WC_SELECT_001 = "WC_SELECT_001";
/** テーブルアクセスクラス(視聴制御ＨＵＬＦＴ送信実績)*/
private JBSbatSQLAccess db_WC_T_WC_HULFT_SDJSK = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
commonItem.getLogPrint().printBusinessErrorLog(JPCBatchMessageConstant.EWCB0010AI,
new String[]{"ディレイド＿CSVリンク＿更新結果確認"});
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
// DBアクセスクラスを生成します
db_WC_T_WC_HULFT_SDJSK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_WC_T_WC_HULFT_SDJSK);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @param inMap 入力電文
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
HashMap itemvalueMap = createMessageMapWCIFE015(inMap.getMap());
//単項目チェックを実施
boolean retcode = isSingleCheckWCIFE015_INF1(inMap.getMap(), itemvalueMap);
if(!retcode)
{
throw new JBSbatBusinessError();
}
String err_code = inMap.getString(JBSbatWCIFE015.ERR_CODE);
String tkn_kiki_seizo_no = inMap.getString(JBSbatWCIFE015.STB_KIKI_SEIZO_NO);
this.logPrint.printDebugLog("*******************************************");
this.logPrint.printDebugLog("エラーコード =" + err_code);
this.logPrint.printDebugLog("機器製造番号 =" + tkn_kiki_seizo_no);
// エラーコードチェック
if(!JWCStrConst.TKN_FILE_ERRCODE_OK.equals(err_code))
{
this.logPrint.printDebugLog("宅内機器管理システムでエラー発生");
commonItem.getLogPrint().printBusinessErrorLog(JPCBatchMessageConstant.EWCB0460CE, new String[]{
err_code,
"機器製造番号:" + tkn_kiki_seizo_no});
throw new JBSbatBusinessError();
}
return null;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_WC_T_WC_HULFT_SDJSK.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
commonItem.getLogPrint().printBusinessErrorLog(JPCBatchMessageConstant.EWCB0020AI,
new String[]{"ディレイド＿CSVリンク＿更新結果確認"});
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**
*入力情報（直接制御（ＣＳＶ）ディレイド受信）の単項目チェックを行います。
*
* 処理フロー
*
* 1.単項目チェックを行います。*
* * 2.メソッドの呼び出し方です。
* 引数: * rsMap:(項目、値)を(key、value)として、データをrsMapに入れます * itemvalueMap:埋め込み文字の値をitemvalueMapに入れます。キーの値は、以下に説明します。 * TXT-WCIFE015-INF1.ERR_CODE 直接制御（ＣＳＶ）ディレイド受信.エラーコード * TXT-WCIFE015-INF1.ERR_CODE 直接制御（ＣＳＶ）ディレイド受信.エラーコード * TXT-WCIFE015-INF1.STB_KIKI_SEIZO_NO 直接制御（ＣＳＶ）ディレイド受信.機器製造番号（ＳＴＢ） * TXT-WCIFE015-INF1.STB_KIKI_SEIZO_NO 直接制御（ＣＳＶ）ディレイド受信.機器製造番号（ＳＴＢ） * TXT-WCIFE015-INF1.CAS_KIKI_SEIZO_NO 直接制御（ＣＳＶ）ディレイド受信.機器製造番号（Ｃ−ＣＡＳ） * TXT-WCIFE015-INF1.CAS_KIKI_SEIZO_NO 直接制御（ＣＳＶ）ディレイド受信.機器製造番号（Ｃ−ＣＡＳ） * TXT-WCIFE015-INF1.STB_ID 直接制御（ＣＳＶ）ディレイド受信.ＳＴＢＩＤ * TXT-WCIFE015-INF1.STB_ID 直接制御（ＣＳＶ）ディレイド受信.ＳＴＢＩＤ * TXT-WCIFE015-INF1.STB_STAT 直接制御（ＣＳＶ）ディレイド受信.ＳＴＢステータスコード * TXT-WCIFE015-INF1.STB_STAT 直接制御（ＣＳＶ）ディレイド受信.ＳＴＢステータスコード * TXT-WCIFE015-INF1.KARI_KEY_OPEN_UK_YMD 直接制御（ＣＳＶ）ディレイド受信.仮鍵開年月日 * TXT-WCIFE015-INF1.KARI_KEY_OPEN_UK_YMD 直接制御（ＣＳＶ）ディレイド受信.仮鍵開年月日 * TXT-WCIFE015-INF1.CTRL_CD 直接制御（ＣＳＶ）ディレイド受信.制御エリアコード * TXT-WCIFE015-INF1.CTRL_CD 直接制御（ＣＳＶ）ディレイド受信.制御エリアコード * TXT-WCIFE015-INF1.CAS_STAT 直接制御（ＣＳＶ）ディレイド受信.Ｃ−ＣＡＳカードステータスコード * TXT-WCIFE015-INF1.CAS_STAT 直接制御（ＣＳＶ）ディレイド受信.Ｃ−ＣＡＳカードステータスコード * TXT-WCIFE015-INF1.S_TAKNKIKI_UPD_YMD 直接制御（ＣＳＶ）ディレイド受信.宅内機器ＳＴＢＴ更新日付 * TXT-WCIFE015-INF1.S_TAKNKIKI_UPD_YMD 直接制御（ＣＳＶ）ディレイド受信.宅内機器ＳＴＢＴ更新日付 * TXT-WCIFE015-INF1.C_TAKNKIKI_UPD_YMD 直接制御（ＣＳＶ）ディレイド受信.宅内機器ＣＡＳＴ更新日付 * TXT-WCIFE015-INF1.C_TAKNKIKI_UPD_YMD 直接制御（ＣＳＶ）ディレイド受信.宅内機器ＣＡＳＴ更新日付 *
* @param rsMap 入力データ（TXT又はDB）を格納されたHashMap。
* @param itemvalueMap エラーメッセージに関する項目値を格納されたHashMap。
* @return boolean trueである場合、エラーがありません。falseである場合、エラーを発生しました。
*/
private boolean isSingleCheckWCIFE015_INF1(HashMap rsMap, HashMap itemvalueMap)
{
// 単項目チェックを行います
String strValue = null;
// エラーコード項目チェック
strValue = (String)rsMap.get("ERR_CODE");
// 必須チェック
if(strValue == null || "".equals(strValue))
{
commonItem.getLogPrint().printBusinessErrorLog("EWCB0070TW", new String[]{
"エラーコード"});
return false;
}
// 桁数チェック
if(!JBSbatCheckUtil.invoke(strValue, new String[]{"ketasuu2", "0", "10"}))
{
commonItem.getLogPrint().printBusinessErrorLog("EWCB0080TW", new String[]{
"エラーコード",
(String)itemvalueMap.get("TXT-WCIFE015-INF1.ERR_CODE")});
return false;
}
// 属性チェック
if(!JBSbatCheckUtil.invoke(strValue, new String[]{"hannkakuesuuji2"}))
{
commonItem.getLogPrint().printBusinessErrorLog("EWCB0090TW", new String[]{
"エラーコード",
(String)itemvalueMap.get("TXT-WCIFE015-INF1.ERR_CODE")});
return false;
}
// 機器製造番号（ＳＴＢ）項目チェック
strValue = (String)rsMap.get("STB_KIKI_SEIZO_NO");
// 必須チェック
if(strValue == null || "".equals(strValue))
{
commonItem.getLogPrint().printBusinessErrorLog("EWCB0070TW", new String[]{
"機器製造番号（ＳＴＢ）"});
return false;
}
// 桁数チェック
if(!JBSbatCheckUtil.invoke(strValue, new String[]{"ketasuu2", "0", "20"}))
{
commonItem.getLogPrint().printBusinessErrorLog("EWCB0080TW", new String[]{
"機器製造番号（ＳＴＢ）",
(String)itemvalueMap.get("TXT-WCIFE015-INF1.STB_KIKI_SEIZO_NO")});
return false;
}
// 属性チェック
if(!JBSbatCheckUtil.invoke(strValue, new String[]{"hannkakuesuuji2"}))
{
commonItem.getLogPrint().printBusinessErrorLog("EWCB0090TW", new String[]{
"機器製造番号（ＳＴＢ）",
(String)itemvalueMap.get("TXT-WCIFE015-INF1.STB_KIKI_SEIZO_NO")});
return false;
}
// 機器製造番号（Ｃ−ＣＡＳ）項目チェック
strValue = (String)rsMap.get("CAS_KIKI_SEIZO_NO");
// 必須チェック
if(strValue == null || "".equals(strValue))
{
commonItem.getLogPrint().printBusinessErrorLog("EWCB0070TW", new String[]{
"機器製造番号（Ｃ−ＣＡＳ）"});
return false;
}
// 桁数チェック
if(!JBSbatCheckUtil.invoke(strValue, new String[]{"ketasuu2", "0", "20"}))
{
commonItem.getLogPrint().printBusinessErrorLog("EWCB0080TW", new String[]{
"機器製造番号（Ｃ−ＣＡＳ）",
(String)itemvalueMap.get("TXT-WCIFE015-INF1.CAS_KIKI_SEIZO_NO")});
return false;
}
// 属性チェック
if(!JBSbatCheckUtil.invoke(strValue, new String[]{"hannkakuesuuji2"}))
{
commonItem.getLogPrint().printBusinessErrorLog("EWCB0090TW", new String[]{
"機器製造番号（Ｃ−ＣＡＳ）",
(String)itemvalueMap.get("TXT-WCIFE015-INF1.CAS_KIKI_SEIZO_NO")});
return false;
}
// ＳＴＢＩＤ項目チェック
strValue = (String)rsMap.get("STB_ID");
// 桁数チェック
if(!JBSbatCheckUtil.invoke(strValue, new String[]{"ketasuu2", "0", "12"}))
{
commonItem.getLogPrint().printBusinessErrorLog("EWCB0080TW", new String[]{
"ＳＴＢＩＤ",
(String)itemvalueMap.get("TXT-WCIFE015-INF1.STB_ID")});
return false;
}
// 属性チェック
if(!JBSbatCheckUtil.invoke(strValue, new String[]{"hannkakuesuuji2"}))
{
commonItem.getLogPrint().printBusinessErrorLog("EWCB0090TW", new String[]{
"ＳＴＢＩＤ",
(String)itemvalueMap.get("TXT-WCIFE015-INF1.STB_ID")});
return false;
}
// ＳＴＢステータスコード項目チェック
strValue = (String)rsMap.get("STB_STAT");
// 桁数チェック
if(!JBSbatCheckUtil.invoke(strValue, new String[]{"ketasuu2", "0", "3"}))
{
commonItem.getLogPrint().printBusinessErrorLog("EWCB0080TW", new String[]{
"ＳＴＢステータスコード",
(String)itemvalueMap.get("TXT-WCIFE015-INF1.STB_STAT")});
return false;
}
// 属性チェック
if(!JBSbatCheckUtil.invoke(strValue, new String[]{"hannkakuesuuji1"}))
{
commonItem.getLogPrint().printBusinessErrorLog("EWCB0090TW", new String[]{
"ＳＴＢステータスコード",
(String)itemvalueMap.get("TXT-WCIFE015-INF1.STB_STAT")});
return false;
}
// 仮鍵開年月日項目チェック
strValue = (String)rsMap.get("KARI_KEY_OPEN_UK_YMD");
// 桁数チェック
if(!JBSbatCheckUtil.invoke(strValue, new String[]{"ketasuu2", "0", "8"}))
{
commonItem.getLogPrint().printBusinessErrorLog("EWCB0080TW", new String[]{
"仮鍵開年月日",
(String)itemvalueMap.get("TXT-WCIFE015-INF1.KARI_KEY_OPEN_UK_YMD")});
return false;
}
// 属性チェック
if(!JBSbatCheckUtil.invoke(strValue, new String[]{"hannkakuesuuji1"}))
{
commonItem.getLogPrint().printBusinessErrorLog("EWCB0090TW", new String[]{
"仮鍵開年月日",
(String)itemvalueMap.get("TXT-WCIFE015-INF1.KARI_KEY_OPEN_UK_YMD")});
return false;
}
// 制御エリアコード項目チェック
strValue = (String)rsMap.get("CTRL_CD");
// 桁数チェック
if(!JBSbatCheckUtil.invoke(strValue, new String[]{"ketasuu2", "0", "6"}))
{
commonItem.getLogPrint().printBusinessErrorLog("EWCB0080TW", new String[]{
"制御エリアコード",
(String)itemvalueMap.get("TXT-WCIFE015-INF1.CTRL_CD")});
return false;
}
// 属性チェック
if(!JBSbatCheckUtil.invoke(strValue, new String[]{"hannkakuesuuji1"}))
{
commonItem.getLogPrint().printBusinessErrorLog("EWCB0090TW", new String[]{
"制御エリアコード",
(String)itemvalueMap.get("TXT-WCIFE015-INF1.CTRL_CD")});
return false;
}
// Ｃ−ＣＡＳカードステータスコード項目チェック
strValue = (String)rsMap.get("CAS_STAT");
// 桁数チェック
if(!JBSbatCheckUtil.invoke(strValue, new String[]{"ketasuu2", "0", "3"}))
{
commonItem.getLogPrint().printBusinessErrorLog("EWCB0080TW", new String[]{
"Ｃ−ＣＡＳカードステータスコード",
(String)itemvalueMap.get("TXT-WCIFE015-INF1.CAS_STAT")});
return false;
}
// 属性チェック
if(!JBSbatCheckUtil.invoke(strValue, new String[]{"hannkakuesuuji1"}))
{
commonItem.getLogPrint().printBusinessErrorLog("EWCB0090TW", new String[]{
"Ｃ−ＣＡＳカードステータスコード",
(String)itemvalueMap.get("TXT-WCIFE015-INF1.CAS_STAT")});
return false;
}
// 宅内機器ＳＴＢＴ更新日付項目チェック
strValue = (String)rsMap.get("S_TAKNKIKI_UPD_YMD");
// 桁数チェック
if(!JBSbatCheckUtil.invoke(strValue, new String[]{"ketasuu2", "0", "17"}))
{
commonItem.getLogPrint().printBusinessErrorLog("EWCB0080TW", new String[]{
"宅内機器ＳＴＢＴ更新日付",
(String)itemvalueMap.get("TXT-WCIFE015-INF1.S_TAKNKIKI_UPD_YMD")});
return false;
}
// 属性チェック
if(!JBSbatCheckUtil.invoke(strValue, new String[]{"hannkakuesuuji1"}))
{
commonItem.getLogPrint().printBusinessErrorLog("EWCB0090TW", new String[]{
"宅内機器ＳＴＢＴ更新日付",
(String)itemvalueMap.get("TXT-WCIFE015-INF1.S_TAKNKIKI_UPD_YMD")});
return false;
}
// 宅内機器ＣＡＳＴ更新日付項目チェック
strValue = (String)rsMap.get("C_TAKNKIKI_UPD_YMD");
// 桁数チェック
if(!JBSbatCheckUtil.invoke(strValue, new String[]{"ketasuu2", "0", "17"}))
{
commonItem.getLogPrint().printBusinessErrorLog("EWCB0080TW", new String[]{
"宅内機器ＣＡＳＴ更新日付",
(String)itemvalueMap.get("TXT-WCIFE015-INF1.C_TAKNKIKI_UPD_YMD")});
return false;
}
// 属性チェック
if(!JBSbatCheckUtil.invoke(strValue, new String[]{"hannkakuesuuji1"}))
{
commonItem.getLogPrint().printBusinessErrorLog("EWCB0090TW", new String[]{
"宅内機器ＣＡＳＴ更新日付",
(String)itemvalueMap.get("TXT-WCIFE015-INF1.C_TAKNKIKI_UPD_YMD")});
return false;
}
return true;
}
/**
* SQLKEY(WC_SELECT_001)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 * HULFT送信年月 * HULFT送信ファイル名 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeWC_T_WC_HULFT_SDJSK_WC_SELECT_001(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
paramList.setValue(param[0].toString());
paramList.setValue(param[1].toString());
// DBアクセスを実行します
db_WC_T_WC_HULFT_SDJSK.selectBySqlDefine(paramList, WC_T_WC_HULFT_SDJSK_WC_SELECT_001);
}
/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
/**
* 受信ファイルのログ出力メッセージを生成する、
*
* @param rsMap
* @return
*/
private HashMap