*
* @author 富士通
*/
public class JBSbatKKKkPlcNoChgTgUpd extends JBSbatBusinessService
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(場所番号連携対象機器ワーク)*/
private static final String D_TBL_NAME_KK_T_PLNO_RNKTGKK_WK = "KK_T_PLNO_RNKTGKK_WK";
/** テーブルアクセスクラス(場所番号連携対象機器ワーク)*/
private JBSbatSQLAccess db_KK_T_PLNO_RNKTGKK_WK = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
// DBアクセスクラスを生成します
db_KK_T_PLNO_RNKTGKK_WK = new JBSbatSQLAccess(commonItem, D_TBL_NAME_KK_T_PLNO_RNKTGKK_WK);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @param inMap 入力電文
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap) throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
super.logPrint.printDebugLog("execute_START");
// 「場所番号連携状態更新ファイル」を読み込みます。
// 場所番号連携対象機器ワーク番号
String plnoRnktgkkWkNo = JBSbatStringUtil.Rtrim(inMap.getString(JBSbatKKIFM189.PLNO_RNKTGKK_WK_NO));
// 場所番号連携状態コード
String placeNoRnkStatCd = JBSbatStringUtil.Rtrim(inMap.getString(JBSbatKKIFM189.PLACE_NO_RNK_STAT_CD));
// 更新年月日時分秒
String updDtm = JBSbatStringUtil.Rtrim(inMap.getString(JBSbatKKIFM189.UPD_DTM));
if (super.logPrint.chkLogLevel(JBSbatLogUtil.MODE_DEBUG))
{
super.logPrint.printDebugLog("場所番号連携対象機器ワーク番号：" + plnoRnktgkkWkNo);
super.logPrint.printDebugLog("場所番号連携状態コード ：" + placeNoRnkStatCd);
}
// 場所番号連携対象機器ワークPK検索メソッドを呼び出し、
// 更新対象の「場所番号連携対象機器ワーク番号」の「更新年月日時分秒」を取得します。
String lastUpdDtmAf = this.getUpdDtm(plnoRnktgkkWkNo);
// 更新日時のチェックを行います。
// 更新日時に相違がある場合、エラー処理を実行します。
if (null == getTimeStampCheck(plnoRnktgkkWkNo, updDtm, lastUpdDtmAf))
{
super.logPrint.printDebugLog("該当データが既に更新されています。" + plnoRnktgkkWkNo);
// MSG 該当データが既に更新されています。（DB:場所番号連携対象機器ワーク KEY:ZZZZZZZZZZ）
super.logPrint.printBusinessErrorLog("EKKB0360KE", new String[]{"場所番号連携対象機器ワーク", plnoRnktgkkWkNo});
return null;
}
// 場所番号連携対象機器ワークの更新を行います。
// 更新対象の「場所番号連携対象機器ワーク番号」のパラメータを設定します。
String [] setParam = {placeNoRnkStatCd}; // 場所番号連携状態コード
String [] whereParam = {plnoRnktgkkWkNo}; // 場所番号連携対象機器ワーク番号
// 場所番号連携対象機器ワークの更新を行います。
this.executeKK_T_PLNO_RNKTGKK_WK_PKUPDATE(setParam, whereParam);
super.logPrint.printDebugLog("execute_END");
return null;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_KK_T_PLNO_RNKTGKK_WK.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* PK(ＰＫ 更新)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数で設定項目マップを作ります。*
* * 2.引数で条件マップを作ります。
* * 3.DBアクセスを実行します。
* * 4.メソッドの呼び出し方です。
* 引数: * setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。 * 場所番号連携状態コード PLACE_NO_RNK_STAT_CD * whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。 * PLNO_RNKTGKK_WK_NO *
* @param setParam 設定項目の値。
* @param whereParam 条件項目の値。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeKK_T_PLNO_RNKTGKK_WK_PKUPDATE(Object[] setParam, Object[] whereParam) throws Exception
{
// 設定値のマップを作成します
JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
setMap.setValue("PLACE_NO_RNK_STAT_CD", setParam[0]);
// 条件のマップを作成します
JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
whereMap.setValue("PLNO_RNKTGKK_WK_NO", whereParam[0]);
// DBアクセスを実行します
db_KK_T_PLNO_RNKTGKK_WK.updateByPrimaryKeys(whereMap, setMap);
}
/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
/**
* 場所番号連携対象機器ワークのPK検索を行います。
*
* @param plnoRnktgkkWkNo 場所番号連携対象機器ワーク番号。
* @return String 更新年月日時分秒。
* @throws Exception メソッド内で発生した例外全般。
*/
private String getUpdDtm(String plnoRnktgkkWkNo) throws Exception
{
// 場所番号連携対象機器ワークをPK検索します。
JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
whereMap.setValue("PLNO_RNKTGKK_WK_NO", plnoRnktgkkWkNo);
// DBアクセスを実行します。
JBSbatCommonDBInterface resultMap = db_KK_T_PLNO_RNKTGKK_WK.selectByPrimaryKeys(whereMap);
// 検索結果なしの場合、エラー処理を実行します。
if (null == resultMap)
{
super.logPrint.printDebugLog("場所番号連携対象機器ワーク情報が存在しません。" + plnoRnktgkkWkNo);
// MSG 場所番号連携対象機器ワークに場所番号連携対象機器ワーク番号:ZZZZZZZZZZが存在しません。
throw new JBSbatBusinessException("EKKB0210CE", new String[]{
"場所番号連携対象機器ワーク", "場所番号連携対象機器ワーク番号:" + plnoRnktgkkWkNo});
}
return JBSbatStringUtil.Rtrim(resultMap.getString(JBSbatKK_T_PLNO_RNKTGKK_WK.UPD_DTM));
}
/**
* タイムスタンプチェックを実施します。
*
* @param plnoRnktgkkWkNo 場所番号連携対象機器ワーク番号。
* @param lastUpdDtmStrBf 最終更新年月日時分秒。
* @param lastUpdDtmStrAf 最終更新年月日時分秒。
* @return JBSbatCommonDBInterface SQL実行結果取得用インターフェース。
* @throws Exception
*/
private JBSbatCommonDBInterface getTimeStampCheck(String plnoRnktgkkWkNo, String lastUpdDtmStrBf, String lastUpdDtmStrAf) throws Exception
{
if (super.logPrint.chkLogLevel(JBSbatLogUtil.MODE_DEBUG))
{
super.logPrint.printDebugLog("更新年月日時分秒(初期検索)：" + lastUpdDtmStrBf);
super.logPrint.printDebugLog("更新年月日時分秒(直前値)::：" + lastUpdDtmStrAf);
}
// タイムスタンプチェックを実施します。
if (lastUpdDtmStrAf.equals(lastUpdDtmStrBf))
{
// 場所番号連携対象機器ワークの排他制御を行います。
// 条件のマップを作成します。
JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
whereMap.setValue("PLNO_RNKTGKK_WK_NO", plnoRnktgkkWkNo);
// DBアクセスを実行します。
JBSbatCommonDBInterface dbmap = db_KK_T_PLNO_RNKTGKK_WK.selectByPrimaryKeysForUpdateWait(whereMap);
if (super.logPrint.chkLogLevel(JBSbatLogUtil.MODE_DEBUG))
{
super.logPrint.printDebugLog("タイムスタンプチェック結果_OK");
}
return dbmap;
}
if (super.logPrint.chkLogLevel(JBSbatLogUtil.MODE_DEBUG))
{
super.logPrint.printDebugLog("タイムスタンプチェック結果_NG");
}
return null;
}
}