MFCで在庫管理システム作成　６

/**
 * @fn
 * @brief	商品IDエディットボックス　キルフォーカス用
 * @param	なし
 * @return	なし
 */
void CEditMain::OnEnKillfocusEditEditmainProductId()
{
	// 略
	
	if (Manager.bGetProductInformation(m_strProductID, strProductNameTemp, strCategory, strUnitPriceTemp, strCurrentCount, strProductAlertTemp) == TRUE)
	{
		// 商品が検索出来た
		m_strProductName = strProductNameTemp;
		m_strUnitPrice = strUnitPriceTemp;
		m_strProductCount = _T("");	// ここのエディットボックスは初期化しておく
		m_strProductAlert = strProductAlertTemp;
		m_strCurrentStock = strCurrentCount;

		// カテゴリーセット
		m_ctrlComboCategory.SelectString(-1, strCategory);	//文字列に合う項目を探し、セット

		// ここから編集用と削除用で分岐
		if (m_enMode == enEdit)
		{
			// 編集処理の場合
			// 推移テキストセット
			CString strText = _T("");
			strText.Format(_T("現在%s⇒変更後XXXXX"), strCurrentCount);
			m_ctrlStaticTransition.SetWindowText(strText);
		}
		else if (m_enMode == enDelete)
		{
			// 削除処理の場合
			m_strProductCount = strCurrentCount;
		}
	}
	else
	{
		// 何かしらエラー
		// 特に何もしない
	}

	//コントロール更新
	UpdateData(FALSE);

}

/**
 * @fn
 * @brief	入力チェック
 * @param	なし
 * @return	なし
 */
BOOL CEditMain::bInutCheck()
{
	// 略

	if (m_enMode == enCreate)
	{
		// 略　作成画面の場合
	}
	else if (m_enMode == enEdit)
	{
		// 略　編集画面の場合
	}
	else if (m_enMode == enDelete)
	{
		// 削除画面の場合
		CString strMessage = _T("");
		strMessage.Format(_T("商品ID：%sを廃番にします。\r\nよろしいですか？"), m_strProductID);
		int iResponse = AfxMessageBox(strMessage, MB_YESNO | MB_ICONQUESTION);
		if (iResponse == IDNO)
		{
			//「いいえ」が押された
			return FALSE;
		}
	}

	return TRUE;
}

/**
 * @fn
 * @brief	OKボタンが押されると呼応される
 * @param	なし
 * @return	なし
 */
void CEditMain::OnBnClickedOk()
{
	// TODO: ここにコントロール通知ハンドラー コードを追加します。
	if (bInutCheck() == TRUE)
	{
		// 略
		if (m_enMode == enCreate)
		{
			// 略　作成処理
		}
		else if (m_enMode == enEdit)
		{
			// 略　編集処理
		}
		else if (m_enMode == enDelete)
		{
			if (Manager.bProductTableDelete(m_strProductID) == TRUE)
			{
				// 削除完了
				AfxMessageBox(_T("削除処理が完了しました。\r\n履歴テーブルを確認してください。"), MB_ICONINFORMATION);
				CDialogEx::OnOK();
			}
			else
			{
				// 失敗した
				return;
			}
		}	
	}
}

/**
 * @fn
 * @brief	商品テーブル　削除関数
 * @param	CString         strProductID    商品ID
 * @return	BOOL    TRUE    削除フラグ更新成功
 *                  FALSE   削除フラグ更新失敗
 */
BOOL CMySQLManager::bProductTableDelete(CString strProductID)
{
    try
    {
        // スキーマセット
        m_con->setSchema(SCHEMA);

        sql::SQLString sqlStrId = strConverter(strProductID);

        //UPDATE文を作る
        sql::SQLString strSqlQuery = "UPDATE " + TABLE_PRODUCT + " SET " + COL_PRODUCT_DISCONTINUE + " = 1 WHERE " + COL_PRODUCT_ID + " = '" + sqlStrId + "'";

        //クエリ実行
        std::unique_ptr<sql::PreparedStatement> pstmt(m_con->prepareStatement(strSqlQuery));
        pstmt->executeUpdate();

        // ここまで処理が来たら、登録成功している
        // 履歴テーブル登録
        if (bLogTableInsert(strProductID, LOG_OPERATION_DELETE, _T("0"), _T("0")) == FALSE)
        {
            AfxMessageBox(_T("履歴テーブルの登録に失敗しました。\r\n管理者へ連絡を！！"), MB_ICONERROR);
            return FALSE;
        }
    }
    catch (sql::SQLException& e)
    {
        ErrSQLException(e);
        return FALSE;
    }

    return TRUE;
}

public:
	// 商品テーブルデータ取得
	BOOL bGetProductData(CString& strProductID, 
						CString& strProductName, 
						CString& strCategory, 
						CString& strUnitPrice, 
						CString& strProductCount, 
						CString& strProductAlert,
						int iRowNum,
						CString strCategoryCondition);

/**
 * @fn
 * @brief	商品テーブル一覧ゲット
 * @param	CString&        strProductID        商品ID
 * @param   CString&        strProductName      商品名
 * @param   CString&        strCategory         カテゴリー
 * @param   CString&        strUnitPrice        単価
 * @param   CString&        strProductCount     在庫数
 * @param   CString&        strProductAlert     在庫アラート
 * @param   int             iRowNum             検索行
 * @param   CString         strCategoryCondition    カテゴリー条件
 * @return	BOOL    TRUE    検索成功
 *                  FALSE   検索失敗
 */
BOOL CMySQLManager::bGetProductData(CString& strProductID,
                                    CString& strProductName,
                                    CString& strCategory,
                                    CString& strUnitPrice,
                                    CString& strProductCount,
                                    CString& strProductAlert,
                                    int iRowNum,
                                    CString strCategoryCondition)
{
    try
    {
        // スキーマセット
        m_con->setSchema(SCHEMA);

        CString strRowNum = _T("");
        strRowNum.Format(_T("%d"), iRowNum); // CString化
        sql::SQLString strSqlRowNum = strConverter(strRowNum);

        sql::SQLString strSqlCategoryCondition = strConverter(strCategoryCondition);


        sql::SQLString sqlStrWithPhase = 
            "WITH NumberedRows AS ( SELECT *, ROW_NUMBER() OVER ( ORDER BY " + COL_LOGS_PRODUCT_ID + " ) AS row_num FROM " + TABLE_PRODUCT;
        // WITH NumberedRows AS ( SELECT *, ROW_NUMBER() OVER ( ORDER BY product_id) AS row_num FROM product)
        sql::SQLString sqlStrWithWherePhaseDis = " WHERE " + COL_PRODUCT_DISCONTINUE + " IS NULL";
        sql::SQLString sqlStrWithWherePhaseCat = " AND " + COL_PRODUCT_CATEGORY + "= '" + strSqlCategoryCondition + "'";

        sql::SQLString sqlStrSelectPhase = " ) SELECT * FROM NumberedRows WHERE row_num = " + strSqlRowNum;
       
        // 最終的なSQL作成
        sql::SQLString strSqlQuery = sqlStrWithPhase + sqlStrWithWherePhaseDis;
        if (strCategoryCondition != _T("*"))
        {
            // 全件検索ではない⇒カテゴリー検索条件を付ける
            strSqlQuery += sqlStrWithWherePhaseCat;
        }
        strSqlQuery += sqlStrSelectPhase;

        //クエリ実行
        std::unique_ptr<sql::PreparedStatement> pstmt(m_con->prepareStatement(strSqlQuery));

        std::unique_ptr<sql::ResultSet> res(pstmt->executeQuery());

        if (!res->next())
        {
            // ここに入れば、もう検索するものはない...
            return FALSE;
        }
        else
        {
            // 該当行発見
            
            // 商品ID
            std::string strCol = res->getString(COL_PRODUCT_ID);
            strProductID = strConvertFromUTF8ToUTF16(strCol);

            // 商品名
            strCol = res->getString(COL_PRODUCT_NAME);
            strProductName = strConvertFromUTF8ToUTF16(strCol);

            // カテゴリー
            strCol = res->getString(COL_PRODUCT_CATEGORY);
            strCategory = strConvertFromUTF8ToUTF16(strCol);

            // 単価
            strCol = res->getString(COL_PRODUCT_UP);
            strUnitPrice = strConvertFromUTF8ToUTF16(strCol);

            // 在庫数
            strCol = res->getString(COL_PRODUCT_COUNT);
            strProductCount = strConvertFromUTF8ToUTF16(strCol);

            // 在庫アラート
            strCol = res->getString(COL_PRODUCT_ALERT);
            strProductAlert = strConvertFromUTF8ToUTF16(strCol);
        }
    }
    catch (sql::SQLException& e)
    {
        ErrSQLException(e);
        return FALSE;
    }

    return TRUE;
}

WITH NumberedRows AS 
     ( SELECT *, ROW_NUMBER() OVER ( ORDER BY product_id) AS row_num FROM product WHERE discontinue IS NULL AND category = 'カテゴリー')
       SELECT * FROM NumberedRows WHERE row_num = 行番号 

private:
	CListCtrl m_ctrlListCtrlProduct;// リストコントロール

private:
	void ShowProductList();	// リストコントロール描画処理

void CInventoryManagementSystemDlg::DoDataExchange(CDataExchange* pDX)
{
	CDialogEx::DoDataExchange(pDX);

	DDX_Control(pDX, IDC_CHECK_MAIN_ALL, m_ctrlCheckSearchAll);		// チェックボックス
	DDX_Control(pDX, IDC_COMBO_MAIN_CATEGORY, m_ctrlComboCategory);	// コンボボックス
	DDX_Control(pDX, IDC_LIST_MAIN_PRODUCT, m_ctrlListCtrlProduct);	// リストコントロール　新規追加
}

BOOL CInventoryManagementSystemDlg::OnInitDialog()
{
	CDialogEx::OnInitDialog();

	// 略

	m_ctrlListCtrlProduct.InsertColumn(0, _T("商品ID"), LVCFMT_LEFT, 100);
	m_ctrlListCtrlProduct.InsertColumn(1, _T("商品名"), LVCFMT_LEFT, 150);
	m_ctrlListCtrlProduct.InsertColumn(2, _T("カテゴリー"), LVCFMT_LEFT, 150);
	m_ctrlListCtrlProduct.InsertColumn(3, _T("単価"), LVCFMT_LEFT, 80);
	m_ctrlListCtrlProduct.InsertColumn(4, _T("在庫数"), LVCFMT_LEFT, 80);
	m_ctrlListCtrlProduct.InsertColumn(5, _T("在庫アラート"), LVCFMT_LEFT, 110);

	ShowProductList();	// 描画処理

	return TRUE;  // フォーカスをコントロールに設定した場合を除き、TRUE を返します。
}

/**
 * @fn
 * @brief	リストコントロール再描画処理
 * @param	なし
 * @return	なし
 */
void CInventoryManagementSystemDlg::ShowProductList()
{
	// 変数更新
	UpdateData(TRUE);

	CString strCategoryCondition = _T("*");	// 全件検索しておく

	if (m_ctrlCheckSearchAll.GetCheck() == BST_UNCHECKED)
	{
		// 全件検索のチェックが外れている
		// ⇒カテゴリー条件アリ
		GetDlgItemText(IDC_COMBO_MAIN_CATEGORY, strCategoryCondition);	// カテゴリー取得
	}

	CMySQLManager Manager;
	Manager.GetConnection();

	LVITEM lvItem{};
	lvItem.mask = LVIF_TEXT;
	int iRoop = 0;

	while (TRUE)
	{
		iRoop++;	// 行番号インクリメント

		CString strProductID = _T("");		// 商品ID
		CString strProductName = _T("");	// 商品名
		CString strCategory = _T("");		// カテゴリー
		CString strUnitPrice = _T("");		// 単価
		CString strProductCount = _T("");	// 在庫数
		CString strProductAlert = _T("");	// 在庫アラート

		if (Manager.bGetProductData(strProductID, strProductName, strCategory, strUnitPrice, strProductCount, strProductAlert, iRoop, strCategoryCondition) == TRUE)
		{
			lvItem.iItem = iRoop - 1;	// リストコントロールの行番号

			// 商品ID列
			lvItem.iSubItem = 0;
			lvItem.pszText = strProductID.GetBuffer();
			m_ctrlListCtrlProduct.InsertItem(&lvItem);

			// 商品名列
			lvItem.iSubItem = 1;
			lvItem.pszText = strProductName.GetBuffer();
			m_ctrlListCtrlProduct.SetItem(&lvItem);

			// カテゴリー列
			lvItem.iSubItem = 2;
			lvItem.pszText = strCategory.GetBuffer();
			m_ctrlListCtrlProduct.SetItem(&lvItem);

			// 単価列
			lvItem.iSubItem = 3;
			lvItem.pszText = strUnitPrice.GetBuffer();
			m_ctrlListCtrlProduct.SetItem(&lvItem);

			// 在庫数列
			lvItem.iSubItem = 4;
			lvItem.pszText = strProductCount.GetBuffer();
			m_ctrlListCtrlProduct.SetItem(&lvItem);

			// 在庫アラート列
			lvItem.iSubItem = 5;
			lvItem.pszText = strProductAlert.GetBuffer();
			m_ctrlListCtrlProduct.SetItem(&lvItem);
		}
		else
		{
			// この場合は、これ以上データをリストに追加できない
			// SQLExceptionも含める
			break;
		}
	}
}

/**
 * @fn
 * @brief	チェックボックスが変更されるたびに呼ばれる
 * @param	なし
 * @return	なし
 */
void CInventoryManagementSystemDlg::OnBnClickedCheckMainAll()
{
	// TODO: ここにコントロール通知ハンドラー コードを追加します。
	SetComboStatus();	// コンボボックスの状態を変更
	ShowProductList();	// リストコントロール再描画処理
}


/**
 * @fn
 * @brief	コンボボックスが編超されるたびに呼ばれる
 * @param	なし
 * @return	なし
 */
void CInventoryManagementSystemDlg::OnCbnSelchangeComboMainCategory()
{
	// TODO: ここにコントロール通知ハンドラー コードを追加します。
	ShowProductList();	// リストコントロール再描画処理
}

/**
 * @fn
 * @brief	編集ボタンが押された
 * @param	なし
 * @return	なし
 */
void CInventoryManagementSystemDlg::OnBnClickedButtonMainEdit()
{
	// 略

	if (bSelectOK == TRUE)
	{
		// 編集画面を表示させる
		CEditMain dlgEditMain;
		dlgEditMain.SetEditSelectMode(enSelectMode);	// モードを設定
		dlgEditMain.DoModal();

		ShowProductList();
	}
}