busupdate.cpp

零件交易系统 零件交易中心管理系统主要提供顾客和供应商之间完成零件交易的功能

// BusUpdate.cpp : implementation file
//

#include "stdafx.h"
#include "Toolmangne.h"
#include "BusUpdate.h"

#ifdef _DEBUG
#define new DEBUG_NEW
#undef THIS_FILE
static char THIS_FILE[] = __FILE__;
#endif

/////////////////////////////////////////////////////////////////////////////
// CBusUpdate dialog

extern CString        UserId;
extern CToolmangneApp theApp;
CBusUpdate::CBusUpdate(CWnd* pParent /*=NULL*/)
	: CDialog(CBusUpdate::IDD, pParent)
{
	//{{AFX_DATA_INIT(CBusUpdate)
	m_info = _T("");
	m_id = _T("");
	m_price = _T("");
	m_num = _T("");
	//}}AFX_DATA_INIT
}


void CBusUpdate::DoDataExchange(CDataExchange* pDX)
{
	CDialog::DoDataExchange(pDX);
	//{{AFX_DATA_MAP(CBusUpdate)
	DDX_Text(pDX, IDC_EDIT1, m_info);
	DDX_Text(pDX, IDC_EDIT2, m_id);
	DDX_Text(pDX, IDC_EDIT3, m_price);
	DDX_Text(pDX, IDC_EDIT4, m_num);
	//}}AFX_DATA_MAP
}


BEGIN_MESSAGE_MAP(CBusUpdate, CDialog)
	//{{AFX_MSG_MAP(CBusUpdate)
	//}}AFX_MSG_MAP
	ON_BN_CLICKED(IDC_BUTTON1, moeity)
	ON_BN_CLICKED(IDC_BUTTON2, Delete)
END_MESSAGE_MAP()

/////////////////////////////////////////////////////////////////////////////
// CBusUpdate message handlers

void CBusUpdate::OnOK() 
{
	// TODO: Add extra validation here	
	//CDialog::OnOK();
	UpdateData();
	CString sql = "select * from OfferToBuy where PartID ="+m_info+" and  CustomerID="+ UserId;
	// TODO: Add extra validation here
	_RecordsetPtr	m_pRecordset;
	 m_pRecordset.CreateInstance(__uuidof(Recordset));
	 try
	 {
		 m_pRecordset->Open(_variant_t(sql),                // 查询DemoTable表中所有字段
			 theApp.m_pConnection.GetInterfacePtr(),	  // 获取库接库的IDispatch指针
			 adOpenDynamic,
			 adLockOptimistic,
			 adCmdText);
		 
		 _variant_t var;
		 if(!m_pRecordset->BOF)
			 m_pRecordset->MoveFirst();
		 else
		 {
			 AfxMessageBox("没有你查找的数据");
			 return ;
		 }			
		 // 读入库中各字段并加入列表框中
		 while(!m_pRecordset->adoEOF)
		 {
			 var = m_pRecordset->GetCollect("PartID");
			 if(var.vt != VT_NULL)
				 m_id = (LPCSTR)_bstr_t(var);
			 var = m_pRecordset->GetCollect("Price");
			 if(var.vt != VT_NULL)
				 m_price = (LPCSTR)_bstr_t(var);
			 var = m_pRecordset->GetCollect("Quantity");
			 if(var.vt != VT_NULL)
				 m_num = (LPCSTR)_bstr_t(var);
			 m_pRecordset->MoveNext();
		 }
	 }
	 catch(_com_error *e)
	 {
		 AfxMessageBox(e->ErrorMessage());
		 return ;
	 }   	
	 UpdateData(false);
	 m_pRecordset->Close();
	 m_pRecordset = NULL;
}

void CBusUpdate::moeity()
{
	UpdateData();
	CString sql = "UPDATE  OfferToBuy Set CustomerID ='"+UserId+"',PartID='"+m_id+"',Price='"+m_price+"',Quantity='"+m_num+"' WHERE  CustomerID="+UserId+" and PartID ="+m_info;	 
	 _RecordsetPtr	m_pRecordset;
	 m_pRecordset.CreateInstance(__uuidof(Recordset));
	 _variant_t RecordsAffected;
	 try
	 {
		 m_pRecordset->Open(_variant_t(sql),                // 查询DemoTable表中所有字段
			 theApp.m_pConnection.GetInterfacePtr(),	  // 获取库接库的IDispatch指针
			 adOpenDynamic,
			 adLockOptimistic,
			 adCmdText);
	 
	 }
	 catch(...)
	 {
		 AfxMessageBox("修改数据失败");
		 return ;
	 }	
	 //m_pRecordset->Close();
	 //m_pRecordset = NULL;
	 //sql = "insert into Provider values ("+"+)";
	 AfxMessageBox("修改数据成功");
}

void CBusUpdate::Delete()
{
	UpdateData();
	CString sql = "delete from OfferToBuy where PartID ="+m_info+" and  CustomerID="+ UserId;
	// TODO: Add extra validation here
	_RecordsetPtr	m_pRecordset;
	 m_pRecordset.CreateInstance(__uuidof(Recordset));
	 try
	 {
		 m_pRecordset->Open(_variant_t(sql),                // 查询DemoTable表中所有字段
			 theApp.m_pConnection.GetInterfacePtr(),	  // 获取库接库的IDispatch指针
			 adOpenDynamic,
			 adLockOptimistic,
			 adCmdText);
	 }
	 catch(_com_error *e)
	 {
		 AfxMessageBox(e->ErrorMessage());
		 return ;
	 }   	
	 AfxMessageBox("删除成功");
}