MFCで物品購入承認システム作成　１０

typedef enum
{
	enPending,		// 申請中
	enApprovaled,	// 承認
	enRejected		// 拒否
}ApprovalMode;

class CMySQLManager
{
public:
	// 申請履歴テーブル登録処理
	BOOL bRecordTableCreate(CString strUserID, CString strGroupID, CString strKoumokuID, ApprovalMode enApproval);
};

#include "MySQLManager.h"

void CRequest::OnBnClickedOk()
{
	// TODO: ここにコントロール通知ハンドラー コードを追加します。
	UpdateData(TRUE);

	int iComboIndex = m_ComboGroup.GetCurSel();	// インデックス取得
	CString strComboText;
	m_ComboGroup.GetLBText(iComboIndex, strComboText);	// コンボボックス内の文字列取得

	int id = GetCheckedRadioButton(IDC_RADIO1, IDC_RADIO5);	// ラジオボタンの選択
	CString strRadioText;
	if (id == IDC_RADIO1 || id == IDC_RADIO2 || id == IDC_RADIO3 || id == IDC_RADIO4 || id == IDC_RADIO5)
	{
		// ラジオボタンからキャプション取得
		GetDlgItemText(id, strRadioText);
	}
	else
	{
		// ラジオボタンが選択されていない場合
		AfxMessageBox(_T("項目を選択してください。"), MB_OK | MB_ICONEXCLAMATION);
		return;
	}
	int iKoumokuID = m_MapKoumokuReverse[strRadioText];		// 項目ID
	KoumokuValue strcutKoumoku = m_MapKoumoku[iKoumokuID];	// 項目IDに対する構造体
	CString strPrice = strcutKoumoku.strKoumokuPrice;		// 選択された項目の値段

	CString strMes = _T("以下を購入申請します。よろしいですか?");
	strMes += _T("\r\nグループ名：");
	strMes += strComboText;
	strMes += _T("\r\n項目名：");
	strMes += strRadioText;
	strMes += _T("\r\n値段：");
	strMes += strPrice;


	if (AfxMessageBox(strMes, MB_OKCANCEL | MB_ICONQUESTION) == IDOK)
	{
		// 申請開始
		// 逆引きからグループIDを取得
		int iGroupID = m_MapGroupReverse[strComboText];		// グループID
		CSupplyRequestManagerApp* pApp = static_cast<CSupplyRequestManagerApp*>(AfxGetApp());
		CString strGroupId, strKoumokuId;
		strGroupId.Format(_T("%d"), iGroupID);
		strKoumokuId.Format(_T("%d"), iKoumokuID);

		CMySQLManager Request;
		Request.GetConnection();	// 接続確立

		if (Request.bRecordTableCreate(pApp->strGetUserId(), strGroupId, strKoumokuId, enPending) == TRUE)
		{
			AfxMessageBox(_T("申請が完了しました。"));
			CDialogEx::OnOK();
		}
	}
}

/**
  * @fn
  * @brief	申請テーブル新規作成処理
  * @param	 CString strUserID               ユーザID
  *          CString strGroupID              グループID
  *          CString strKoumokuID            項目ID 
  *          ApprovalMode enApproval         申請状態(=enPending)
  * @return	 TRUE    操作成功
  *          FALSE   操作失敗
  */
BOOL CMySQLManager::bRecordTableCreate(CString strUserID, CString strGroupID, CString strKoumokuID, ApprovalMode enApproval)
{
    switch (enApproval)
    {
    case enPending:
        // 申請中を登録
        break;
    default:
        AfxMessageBox(_T("処理に問題があります。管理者へ連絡を！"));
        return FALSE;
    }

    try
    {
        m_con->setSchema(SCHEMA);   //スキーマ選択
        sql::SQLString strSqlQuery = "";

        // 各種型変換
        sql::SQLString strsqlUserID = strConverter(strUserID);          // ユーザID
        sql::SQLString strsqlGroupID = strConverter(strGroupID);        // グループID
        sql::SQLString strsqlKoumokuID = strConverter(strKoumokuID);    // 項目ID
        sql::SQLString strsqlApproval = strConverter(_T("0"));          // 申請状態(申請中)

        // 本当にグループIDは存在する？
        strSqlQuery = "SELECT * FROM " + TABLE_GROUP + " WHERE Id = " + strsqlGroupID;
        // クエリを実行
        std::unique_ptr<sql::PreparedStatement> pstmt1(m_con->prepareStatement(strSqlQuery));
        std::unique_ptr<sql::ResultSet> res1(pstmt1->executeQuery());
        if (!res1->next())
        {
            AfxMessageBox(_T("グループテーブルに問題があります。管理者へ連絡を！"));
            return FALSE;
        }

        // 本当に項目IDは存在する？
        strSqlQuery = "SELECT * FROM " + TABLE_KOUMOKU + " WHERE Id = " + strsqlKoumokuID;
        // クエリを実行
        std::unique_ptr<sql::PreparedStatement> pstmt2(m_con->prepareStatement(strSqlQuery));
        std::unique_ptr<sql::ResultSet> res2(pstmt2->executeQuery());
        if (!res2->next())
        {
            AfxMessageBox(_T("項目テーブルに問題があります。管理者へ連絡を！"));
            return FALSE;
        }

        //登録処理開始
        strSqlQuery = "INSERT INTO " + TABLE_RECORD + " (UserId, KoumokuId, Approval) VALUES ('" + strsqlUserID + "', " + strsqlKoumokuID + ", " + strsqlApproval + ")";
        // クエリを実行
        std::unique_ptr<sql::PreparedStatement> pstmt3(m_con->prepareStatement(strSqlQuery));
        std::unique_ptr<sql::ResultSet> res3(pstmt3->executeQuery());

    }
    catch (sql::SQLException& e)
    {
        // 実行できなかった
        ErrSQLException(e);
        return FALSE;
    }

    return TRUE;
}