/********************************************************************* * All Rights reserved,Copyright (c) K-Opticom ********************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JECH0011C012TPMA * ソースファイル名：JECH0011C012TPMA.java * 作成者 ：富士通 * 日付 ：2011年08月02日 *＜機能概要＞ * 入金取消債権変更顧客独自処理部品 *＜修正履歴＞ * バージョン 修正日 修正者 修正内容 * v1.00.00 2011/08/02 富士通 新規作成 * **********************************************************************/ package eo.ejb.cbs.mainproc; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import com.fujitsu.futurity.model.base.CAANConnectionMgr; import com.fujitsu.futurity.model.base.CAANJDBCUtil; import com.fujitsu.futurity.model.base.CAANMsg; import com.fujitsu.futurity.model.base.CAANRuntimeException; import com.fujitsu.futurity.model.ejb.common.JSYejbConnection; import com.fujitsu.futurity.model.ejb.common.JSYejbLog; import com.fujitsu.futurity.model.ejb.common.StatusCodes; import com.fujitsu.futurity.model.ejb.common.fw.AgentDispatchContext; import com.fujitsu.futurity.model.ejb.common.fw.TemplateMainHandler; import eo.ejb.cbm.entity.CH0011ETMsg; import eo.ejb.cbm.entity.CH0401ETMsg; import eo.ejb.cbs.cbsmsg.ECH0011C013CBSMsg; import eo.ejb.cbs.cbsmsg.ECH0101B010CBSMsg; import eo.ejb.common.JCHModelCommon; import eo.ejb.common.JPCModelCommon; import eo.ejb.common.db.JCHejbCH0021SecProc; /** *

* 入金取消時の請求内訳の更新を行う部品 *

* @author 富士通 */ public class JECH0101C010TPMA implements TemplateMainHandler { /** * コンストラクタです。 */ public JECH0101C010TPMA() { super(); } /** *

* 入金取消時の債権内訳の更新を行います。 *

* @param inMsg 処理対象のメッセージキャリア * @param inContext Agentから渡されたAgentDispatchContext */ public static void invoke(CAANMsg inCBSMsg, AgentDispatchContext inContext) { // エラーフラグ String errFlag = "EA"; CAANMsg serchCaanMsg = new CAANMsg(CH0011ETMsg.class.getName()); serchCaanMsg.set(CH0011ETMsg.SAIKEN_NO, inCBSMsg.getString((ECH0011C013CBSMsg.SAIKEN_NO))); serchCaanMsg.set(CH0011ETMsg.UPD_DTM, inCBSMsg.getString((ECH0011C013CBSMsg.SAIKEN_UPD_DTM_AF))); // 債権排他チェック処理 // if (!JPCModelCommon.succeededExclusiveLock(inCBSMsg,inContext, "CH0011")) { if (!JCHModelCommon.succeededExclusiveLock(serchCaanMsg,inContext, "CH0011")) { inCBSMsg.set(ECH0011C013CBSMsg.SAIKEN_UPD_DTM_AF_ERR, errFlag); inCBSMsg.set(ECH0011C013CBSMsg.STATUS, StatusCodes.RELATION_ERR); return; } if (!"1".equals(inCBSMsg.getString(ECH0011C013CBSMsg.FUNC_CODE))) { return; } // ---------------------------------------------------- // 債権内訳.充当額を更新する // ---------------------------------------------------- // コネクション Connection con1 = null; // プリペアステートメント PreparedStatement pstmt = null; // リザルトセット ResultSet rsltQuery = null; // 債権の副次問合せ JCHejbCH0021SecProc CH0021 = new JCHejbCH0021SecProc(); /******************** * SQL文の作成 ********************/ try { // コネクション取得 con1 = JSYejbConnection.getConnection(CH0401ETMsg.getTableName()); StringBuffer sql_Buff = new StringBuffer(); sql_Buff .append(" SELECT ") .append(" CH0401.PRC_GRP_CD ") .append(" ,CH0401.PCRS_CD ") .append(" ,CH0401.PRC_SVC_CD ") .append(" ,CH0401.PRC_KMK_CD ") .append(" FROM ") .append(" CH_M_PRC_KMK_CS_CHGE CH0401 ") .append(" WHERE ") .append(" CH0401.SYS_CD = 'CH' ") .append(" AND CH0401.WORK_KINO_SKBT_CD = ? ") .append(" AND CH0401.PRC_KMK_CS_CHGE_TSTAYMD <= ? ") .append(" AND CH0401.PRC_KMK_CS_CHGE_TENDYMD >= ? ") .append(" AND CH0401.MK_FLG = '0' "); // prepareStatementにSQL文をセット pstmt = con1.prepareStatement(sql_Buff.toString()); // ログ出力(SQL文の出力) JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS,JECH0101C010TPMA.class, sql_Buff); int i = 1; // パラメータの設定(充当額＿業務機能識別コードを指定) CAANJDBCUtil.setParam(pstmt, i++, inCBSMsg.getString(ECH0011C013CBSMsg.JUTO_APL_KINO_CD)); // パラメータの設定(運用日を指定) CAANJDBCUtil.setParam(pstmt, i++, JPCModelCommon.getOpeDate(inCBSMsg, inContext, null)); // パラメータの設定(運用日を指定) CAANJDBCUtil.setParam(pstmt, i++, JPCModelCommon.getOpeDate(inCBSMsg, inContext, null)); // ResultSetの取得 rsltQuery = pstmt.executeQuery(); // 戻り値の判定 if (rsltQuery.next()) { // 料金グループコードを取得する String sPRC_GRP_CD = rsltQuery.getString(CH0401ETMsg.PRC_GRP_CD); // 料金コースコードを取得する String sPCRS_CD = rsltQuery.getString(CH0401ETMsg.PCRS_CD); // 料金サービスコードを取得する String sPRC_SVC_CD = rsltQuery.getString(CH0401ETMsg.PRC_SVC_CD); // 料金項目コードを取得する String sPRC_KMK_CD = rsltQuery.getString(CH0401ETMsg.PRC_KMK_CD); // 債権内訳副次問合せを呼び出し、債権内訳の充当額を更新する CH0021.updateJutoAmnt(inCBSMsg, inContext, sPRC_GRP_CD, sPCRS_CD, sPRC_SVC_CD, sPRC_KMK_CD); } } catch (SQLException e) { inCBSMsg.set(CH0401ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // 資源の解放 try { if (rsltQuery != null) { rsltQuery.close(); } if (pstmt != null) { pstmt.close(); } if (con1 != null) { CAANConnectionMgr.getInstance().close(con1); } } catch (SQLException e) { inCBSMsg.set(CH0401ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } // ---------------------------------------------------- // 債権内訳.未収額を更新する // ---------------------------------------------------- /******************** * SQL文の作成 ********************/ try { // コネクション取得 con1 = JSYejbConnection.getConnection(CH0401ETMsg.getTableName()); StringBuffer sql_Buff = new StringBuffer(); sql_Buff .append(" SELECT ") .append(" CH0401.PRC_GRP_CD ") .append(" ,CH0401.PCRS_CD ") .append(" ,CH0401.PRC_SVC_CD ") .append(" ,CH0401.PRC_KMK_CD ") .append(" FROM ") .append(" CH_M_PRC_KMK_CS_CHGE CH0401 ") .append(" WHERE ") .append(" CH0401.SYS_CD = 'CH' ") .append(" AND CH0401.WORK_KINO_SKBT_CD = ? ") .append(" AND CH0401.PRC_KMK_CS_CHGE_TSTAYMD <= ? ") .append(" AND CH0401.PRC_KMK_CS_CHGE_TENDYMD >= ? ") .append(" AND CH0401.MK_FLG = '0' "); // prepareStatementにSQL文をセット pstmt = con1.prepareStatement(sql_Buff.toString()); // ログ出力(SQL文の出力) JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS,JECH0101C010TPMA.class, sql_Buff); int i = 1; // パラメータの設定(未収額＿業務機能識別コードを指定) CAANJDBCUtil.setParam(pstmt, i++, inCBSMsg.getString(ECH0011C013CBSMsg.MISY_APL_KINO_CD)); // パラメータの設定(運用日を指定) CAANJDBCUtil.setParam(pstmt, i++, JPCModelCommon.getOpeDate(inCBSMsg, inContext, null)); // パラメータの設定(運用日を指定) CAANJDBCUtil.setParam(pstmt, i++, JPCModelCommon.getOpeDate(inCBSMsg, inContext, null)); // ResultSetの取得 rsltQuery = pstmt.executeQuery(); // 戻り値の判定 if (rsltQuery.next()) { // 料金グループコードを取得する String sPRC_GRP_CD = rsltQuery.getString(CH0401ETMsg.PRC_GRP_CD); // 料金コースコードを取得する String sPCRS_CD = rsltQuery.getString(CH0401ETMsg.PCRS_CD); // 料金サービスコードを取得する String sPRC_SVC_CD = rsltQuery.getString(CH0401ETMsg.PRC_SVC_CD); // 料金項目コードを取得する String sPRC_KMK_CD = rsltQuery.getString(CH0401ETMsg.PRC_KMK_CD); // 債権内訳副次問合せを呼び出し、債権内訳の未収額を更新する CH0021.updateMisyAmnt(inCBSMsg, inContext, sPRC_GRP_CD, sPCRS_CD, sPRC_SVC_CD, sPRC_KMK_CD); } } catch (SQLException e) { inCBSMsg.set(CH0401ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // 資源の解放 try { if (rsltQuery != null) { rsltQuery.close(); } if (pstmt != null) { pstmt.close(); } if (con1 != null) { CAANConnectionMgr.getInstance().close(con1); } } catch (SQLException e) { inCBSMsg.set(CH0401ETMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } } }