*
* @author 富士通
*/
public class JBSbatCKKnyshaKokanInfCst extends JBSbatBusinessService
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(不良顧客)*/
private static final String D_TBL_NAME_CK_T_HURYO_CUST = "CK_T_HURYO_CUST";
/** テーブルアクセスクラス(不良顧客)*/
private JBSbatSQLAccess db_CK_T_HURYO_CUST = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
/**
* ゼロ
*/
private static final String ZERO = "0";
/**
* 不良顧客移動電話番号 固定値
*/
private static final String THURYO_CUST_MOVE_TELNO_FIXED_VALUE = "08000000000";
/**
* 自事業者コード(TCA) ケイ・オプティコム
*/
private static final String JI_JIGYOSHA_CD_KOPT = "3200";
// OM-2014-0002159 ADD START
/**
* 不良顧客名カナ出力文字数
*/
private static final Integer HURYO_CUST_KANA_MAX = 50;
/**
* 不良顧客住所名出力文字数
*/
private static final Integer HURYO_CUST_ADDRESS_MAX = 107;
// OM-2014-0002159 ADD END
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
// DBアクセスクラスを生成します
db_CK_T_HURYO_CUST = new JBSbatSQLAccess(commonItem, D_TBL_NAME_CK_T_HURYO_CUST);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @param inMap 入力電文
* @param outputInItem 入力情報
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute(JBSbatServiceInterfaceMap inMap, JBSbatOutputItem outputInItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
// INPUTの読み込みが全て終了した時点で、メイン処理を実行する
// 入力データ単位のコミットを
if(inMap == null)
{
// INPUTの読み込みが全て終了した場合
if (outputInItem == null)
{
// INPUTが0件の場合は、execute自体が呼び出しされない
return null;
}
// メイン処理
JBSbatOutputItem outputItem = mainProp(outputInItem);
return outputItem;
}
else
{
// INPUTの読み込みが全て終了していない場合
// 退避レコード格納リストに、現レコードを保存して、処理を終了する
outputInItem.addOutMapList(inMap);
return outputInItem;
}
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_CK_T_HURYO_CUST.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* PK(ＰＫ 更新)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数で設定項目マップを作ります。*
* * 2.引数で条件マップを作ります。
* * 3.DBアクセスを実行します。
* * 4.メソッドの呼び出し方です。
* 引数: * setParam:設定したい項目の(項目、値)を(key、value)として、setParamマップに入れます。項目キーは以下に説明します。 * 加入者交換出力開始年月 KNYSHA_KOKAN_OUTPUT_STA_YM * whereParam:PK項目の(項目、値)を(key、value)として,格納された配列です。PK項目は以下に説明します。 * HURYO_CUST_NO *
* @param setParam 設定項目の値。
* @param whereParam 条件項目の値。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeCK_T_HURYO_CUST_PKUPDATE(Object[] setParam, Object[] whereParam) throws Exception
{
// 設定値のマップを作成します
JBSbatCommonDBInterface setMap = new JBSbatCommonDBInterface();
setMap.setValue("KNYSHA_KOKAN_OUTPUT_STA_YM", setParam[0]);
// 条件のマップを作成します
JBSbatCommonDBInterface whereMap = new JBSbatCommonDBInterface();
whereMap.setValue("HURYO_CUST_NO", whereParam[0]);
// DBアクセスを実行します
db_CK_T_HURYO_CUST.updateByPrimaryKeys(whereMap, setMap);
}
/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
/**
* メイン処理
* @param outputInItem 入力情報
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
private JBSbatOutputItem mainProp(JBSbatOutputItem outputInItem) throws Exception
{
// 戻り値の出力情報
JBSbatOutputItem outputItem = new JBSbatOutputItem();
// 退避レコード格納リスト数分、繰り返す。
for (int i = 0; i < outputInItem.getOutMapList().size(); i++)
{
// 入力ファイル情報から処理中のレコード情報を取得
JBSbatServiceInterfaceMap inRecordMap = (JBSbatServiceInterfaceMap)outputInItem.getOutMapList().get(i);
// ■出力ファイル編集
JBSbatServiceInterfaceMap outMap = new JBSbatServiceInterfaceMap();
// 不良顧客カナ名
outMap.set(JBSbatCKIFM003.HURYO_CUST_KANA, convHuryoCustKana(inRecordMap.getString(JBSbatCK_T_HURYO_CUST.HURYO_CUST_KANA)));
// 不良顧客名
outMap.set(JBSbatCKIFM003.HURYO_CUST_NM , JBSbatInterface.charConverter(inRecordMap.getString(JBSbatCK_T_HURYO_CUST.HURYO_CUST_NM)));
// 不良顧客生年月日
outMap.set(JBSbatCKIFM003.HURYO_CUST_BIRTHD , inRecordMap.getString(JBSbatCK_T_HURYO_CUST.HURYO_CUST_BIRTHD));
// 不良顧客性別コード
outMap.set(JBSbatCKIFM003.HURYO_CUST_SEX_CD, convHuryoCustSexCd(inRecordMap.getString(JBSbatCK_T_HURYO_CUST.HURYO_CUST_SEX_CD)));
// 不良顧客郵便番号
outMap.set(JBSbatCKIFM003.HURYO_CUST_PCD, inRecordMap.getString(JBSbatCK_T_HURYO_CUST.HURYO_CUST_PCD));
// 不良顧客住所名
// OM-2014-0002159 CHANGE START
// outMap.set(JBSbatCKIFM003.HURYO_CUST_AD_NM , JBSbatInterface.charConverter(inRecordMap.getString(JBSbatCK_T_HURYO_CUST.HURYO_CUST_AD_NM)));
outMap.set(JBSbatCKIFM003.HURYO_CUST_AD_NM , JKKBatCommon.getLCutString(JBSbatInterface.charConverter(inRecordMap.getString(JBSbatCK_T_HURYO_CUST.HURYO_CUST_AD_NM)),HURYO_CUST_ADDRESS_MAX));
// OM-2014-0002159 CHANGE END
// 不良顧客住所コード
outMap.set(JBSbatCKIFM003.HURYO_CUST_AD_CD , null);
// 不良顧客電話番号
outMap.set(JBSbatCKIFM003.HURYO_CUST_TELNO , inRecordMap.getString(JBSbatCK_T_HURYO_CUST.HURYO_CUST_TELNO));
// 不良顧客移動電話番号
outMap.set(JBSbatCKIFM003.HURYO_CUST_MOVE_TELNO , THURYO_CUST_MOVE_TELNO_FIXED_VALUE);
// 顧客番号
outMap.set(JBSbatCKIFM003.SYSID , inRecordMap.getString(JBSbatCK_T_HURYO_CUST.SYSID));
// 事業者コード
outMap.set(JBSbatCKIFM003.HURYO_CUST_JIGYOSHA_CD , JI_JIGYOSHA_CD_KOPT + JI_JIGYOSHA_CD_KOPT);
// 滞納金額
outMap.set(JBSbatCKIFM003.NONPAY_AMNT , inRecordMap.getBigDecimal(JBSbatCK_T_HURYO_CUST.NONPAY_AMNT).toString());
outMap.setOutFlg(true);
outputItem.addOutMapList(outMap);
// ■DB処理
updateHuryoCust(inRecordMap.getString(JBSbatCK_T_HURYO_CUST.HURYO_CUST_NO), super.opeDate.substring(0, 6));
}
return outputItem;
}
/**
* 不良顧客カナ名の編集仕様に則って独自変換します
*
* @param huryoCustKana 不良顧客カナ名
* @return 変換後の不良顧客カナ名
* @throws Exception
*/
private String convHuryoCustKana(String huryoCustKana) throws Exception
{
String convStr = huryoCustKana;
// 変換テーブル
// カンマ → 半角スペース
final String[][] CONVTBL = {
{",", " "}
};
// 全角→半角変換
if(!JKKStringUtil.isNullEmpty(convStr))
{
convStr = JKKStringConverter.convertHalf(huryoCustKana);
}
//
if(!JKKStringUtil.isNullEmpty(convStr))
{
for (int i = 0; i < CONVTBL.length; i++)
{
convStr = convStr.replaceAll(CONVTBL[i][0], CONVTBL[i][1]);
}
}
// OM-2014-0002159 ADD START
// 不良顧客カナ名が50文字以上の場合は、先頭から50文字だけを出力
convStr = JKKBatCommon.getLCutString(convStr, HURYO_CUST_KANA_MAX);
// OM-2014-0002159 ADD END
return convStr;
}
/**
* 不良顧客性別コードの編集仕様に則って独自変換します
*
* @param huryoCustSexCd 不良顧客性別コード
* @return 変換後の不良顧客性別コード
* @throws Exception
*/
private String convHuryoCustSexCd(String huryoCustSexCd) throws Exception
{
String convStr = "";
// 不良顧客性別コードが"1"または"2"の場合
if(JKKStrConst.CD00245_1.equals(huryoCustSexCd) || JKKStrConst.CD00245_2.equals(huryoCustSexCd))
{
// 「"0" + 不良顧客性別コード」を不良顧客性別コード文字列に設定
convStr = ZERO + huryoCustSexCd;
}
else
{
// 上記以外の場合、空文字
}
return convStr;
}
/**
* 不良顧客の更新処理をします。
*
* @param huryoCustNo 不良顧客番号
* @param knyshaKokanOutputStaYm 加入者交換出力年月
*
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void updateHuryoCust(String huryoCustNo, String knyshaKokanOutputStaYm) throws Exception
{
JBSbatCommonDBInterface map = new JBSbatCommonDBInterface();
JBSbatCommonDBInterface where_map = new JBSbatCommonDBInterface();
String[] value = null;
String[] param = null;
where_map.setValue(JBSbatCK_T_HURYO_CUST.HURYO_CUST_NO, huryoCustNo);
// 排他検索を行います
map = db_CK_T_HURYO_CUST.selectByPrimaryKeysForUpdateWait(where_map);
// 排他検索結果がある場合
if (map != null)
{
value = new String[1];
param = new String[1];
value[0] = knyshaKokanOutputStaYm;
param[0] = huryoCustNo;
executeCK_T_HURYO_CUST_PKUPDATE(value, param);
}
// 排他エラーの場合
else
{
// 該当レコード無しのエラー
throw new JBSbatBusinessException(JPCBatchMessageConstant.EKKB0210CE,
new String[]{"不良顧客", "不良顧客番号" + huryoCustNo});
}
}
}