开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 行业应用 > 家庭/个人应用 > 查看源码
DBOperator.cpp
资源名称：jiatingcaiwuguanli+VC.rar　[点击查看]
上传用户：xiaoke98
上传日期：2014-06-29
资源大小：5718k
文件大小：40k
源码类别：

家庭/个人应用

开发平台：

Visual C++

DBOperator.cpp：源码内容
  1. // DBOperator.cpp: implementation of the CDBOperator class.
  2. //
  3. //////////////////////////////////////////////////////////////////////
  5. #include "stdafx.h"
  6. #include "HomeFinanceManager.h"
  7. #include "DBOperator.h"
  8. #include "SysStatus.h"
  10. #ifdef _DEBUG
  11. #undef THIS_FILE
  12. static char THIS_FILE[]=__FILE__;
  13. #define new DEBUG_NEW
  14. #endif
  16. //////////////////////////////////////////////////////////////////////
  17. // Construction/Destruction
  18. //////////////////////////////////////////////////////////////////////
  20. CDBOperator gDBOperator;
  22. CDBOperator::CDBOperator()
  23. {
  24. //获取系统目录
  25. char strModuleFileName[400];
  26. ::GetModuleFileName(NULL, strModuleFileName, 400);
  27. char* pChar = strModuleFileName;
  28. while(*(pChar++) != ''){};
  29. while(*(pChar--) != '\'){};
  30. *(++pChar) = '';
  31. m_strAppPath = strModuleFileName;
  33. if(ConnectToDB() == FALSE)
  34. {
  35. AfxMessageBox("连接的数据库不存在!系统将会退出");
  36. ExitProcess(1);
  37. }
  39. }
  41. CDBOperator::~CDBOperator()
  42. {
  43. ::CoUninitialize();
  44. }
  46. BOOL  CDBOperator::ConnectToDB(void)
  47. {
  48. ::CoInitialize(NULL);
  49. try
  50. {
  51. m_DBConnection.CreateInstance(__uuidof(Connection));
  52. CString strConnectStr;
  53. strConnectStr.Format("Provider=Microsoft.Jet.OLEDB.4.0; Data Source=%s\HomeFinanceManager.mdb",
  54. m_strAppPath);
  56. m_DBConnection->CursorLocation = adUseClient;
  57. m_DBConnection->Open(_bstr_t( strConnectStr.GetBuffer(0)), L"", L"", -1);
  59. m_Command.CreateInstance(__uuidof(Command));
  60. m_Command->ActiveConnection = m_DBConnection;
  61. m_Command->CommandType = adCmdText;
  63. m_Recordset.CreateInstance(__uuidof(Recordset));
  66. return TRUE;
  67. }catch(_com_error &e)
  68. {
  70. _bstr_t bstrSource(e.Source());
  71.         _bstr_t bstrDescription(e.Description());
  72.         TRACE("Exception throw for classes generated by #import");
  73.         TRACE("tCode=%08lxn", e.Error);
  74.         TRACE("tCode meaning = %sn", e.ErrorMessage);
  75.         TRACE("tSource = %sn", (LPCTSTR)bstrSource);
  76.         TRACE("tDescription = %sn", (LPCTSTR)bstrDescription);
  77. return FALSE;
  78. }
  80. return FALSE;
  81. }
  82. //-------------------------------------------------------------------------------------------------
  84. BOOL CDBOperator::addUser(CString strUserName, CString strPassword, char* pImgData, int iDataLen)
  85. {
  86. CString strSQL;
  87. strSQL.Format("select * from userinfo");
  88. try
  89. {
  90. long state = m_Recordset->GetState();
  91. if(state)
  92. {
  93. m_Recordset->Close();
  94. }
  95. m_Recordset->Open("SELECT * FROM UserInfo",_variant_t((IDispatch *)m_DBConnection,true),adOpenDynamic,adLockPessimistic,adCmdText);
  96. state = m_Recordset->GetState();
  97. m_Recordset->AddNew();
  98. m_Recordset->PutCollect("UserName",_variant_t(strUserName));
  99. m_Recordset->PutCollect("Passwd",_variant_t(strPassword));
  101. state = m_Recordset->GetState();
  102. //添加图片信息
  103. char *pBuf = pImgData;
  104. VARIANT varBLOB;
  105. SAFEARRAY *psa;
  106. SAFEARRAYBOUND rgsabound[1];
  107. if(pBuf)
  108. {    
  109. rgsabound[0].lLbound = 0;
  110. rgsabound[0].cElements = iDataLen;
  111. psa = SafeArrayCreate(VT_UI1, 1, rgsabound);
  112. for (long i = 0; i < (long)iDataLen; i++)
  113. SafeArrayPutElement (psa, &i, pBuf++);
  114. varBLOB.vt = VT_ARRAY | VT_UI1;
  115. varBLOB.parray = psa;
  116. m_Recordset->GetFields()->GetItem("UserImg")->AppendChunk(varBLOB);
  117. }
  120. m_Recordset->Update();
  122. }
  123. catch(_com_error &e)
  124. {
  125. bstr_t bstrSource(e.Source());
  126.         _bstr_t bstrDescription(e.Description());
  127.         TRACE("Exception throw for classes generated by #import");
  128.         TRACE("tCode=%08lxn", e.Error);
  129.         TRACE("tCode meaning = %sn", e.ErrorMessage);
  130.         TRACE("tSource = %sn", (LPCTSTR)bstrSource);
  131.         TRACE("tDescription = %sn", (LPCTSTR)bstrDescription);
  132. }
  134. AfxMessageBox("成功添加新用户");
  135. return TRUE;
  136. }
  138. //-------------------------------------------------------------------------------------
  140. BOOL  CDBOperator::getUserImg(CString strUserName, char** pImageData, int& iDataLen)
  141. {
  142. CString strSQL;
  143. strSQL.Format("select UserImg from userinfo where UserName='%s'",
  144. strUserName.GetBuffer(0));
  146. try
  147. {
  148. m_Command->CommandText = (_bstr_t) strSQL.GetBuffer(0);
  149. _variant_t vra;
  150. VARIANT *vt1 = NULL;
  151. m_Recordset = m_Command->Execute(&vra, vt1, adCmdText);
  152. if(m_Recordset->adoEOF)
  153. {
  154. return FALSE;
  155. }
  156. iDataLen = m_Recordset->GetFields()->GetItem("UserImg")->ActualSize;
  158. if(iDataLen > 0)
  159. {
  160. *pImageData = new char[iDataLen + 1];
  161. _variant_t varBLOB;
  162. varBLOB = m_Recordset->GetFields()->GetItem("UserImg")->GetChunk(iDataLen);
  163. if(varBLOB.vt == (VT_ARRAY | VT_UI1))
  164. {
  165. char *pBuf = NULL;
  166. SafeArrayAccessData(varBLOB.parray,(void **)&pBuf);
  167. memcpy(*pImageData,pBuf,iDataLen); ///复制数据到缓冲区m_pBMPBuffer
  168. SafeArrayUnaccessData (varBLOB.parray);
  169. }
  171. return TRUE;
  172. }
  175. return FALSE;
  176. }
  178. catch(_com_error &e)
  179. {
  180. bstr_t bstrSource(e.Source());
  181.         _bstr_t bstrDescription(e.Description());
  182.         TRACE("Exception throw for classes generated by #import");
  183.         TRACE("tCode=%08lxn", e.Error);
  184.         TRACE("tCode meaning = %sn", e.ErrorMessage);
  185.         TRACE("tSource = %sn", (LPCTSTR)bstrSource);
  186.         TRACE("tDescription = %sn", (LPCTSTR)bstrDescription);
  187. }
  190. return TRUE;
  192. }
  193. //-------------------------------------------------------------------------------------------------
  195. BOOL CDBOperator::VerifyUser(CString& strUser, CString& strPasswd)
  196. {
  197. try
  198. {
  199. CString strSQL;
  200. strSQL.Format("select * from userinfo where UserName='%s' and Passwd='%s'", 
  201.            strUser.GetBuffer(0),
  202.    strPasswd.GetBuffer(0));
  203. m_Command->CommandText = (_bstr_t) strSQL.GetBuffer(0);
  205. _variant_t vra;
  206. VARIANT *vt1 = NULL;
  207. m_Recordset = m_Command->Execute(&vra, vt1, adCmdText);
  208.     if(m_Recordset->adoEOF)
  209. {
  210. return FALSE;
  211. }
  212. return TRUE;
  214. }
  215. catch(_com_error &e)
  216. {
  218. _bstr_t bstrSource(e.Source());
  219. _bstr_t bstrDescription(e.Description());
  220. TRACE("Exception throw for classes generated by #import");
  221. TRACE("tCode=%08lxn", e.Error);
  222. TRACE("tCode meaning = %sn", e.ErrorMessage);
  223. TRACE("tSource = %sn", (LPCTSTR)bstrSource);
  224. TRACE("tDescription = %sn", (LPCTSTR)bstrDescription);
  225. return FALSE;
  226. }
  227. return FALSE;
  228. }
  229. //-------------------------------------------------------------------------------------------------
  231. void    CDBOperator::selectFinanceIn(CString& strStartTime, CString& strEndTime, CFinanceDBGrid& DBGrid, CString& strTotalIn, SELECTORDER order)
  232. {
  233. try
  234. {
  235. CString strSQL;
  236. CString strCondtionSQL;
  237. strCondtionSQL.Format("where MoneyIncome.InDate between #%s# and #%s#", strStartTime, strEndTime);
  239. _variant_t vra;
  240. VARIANT *vt1 = NULL;
  242. strSQL.Format("select SUM(MoneyIncome.InMoney) from MoneyIncome %s", strCondtionSQL);
  243. m_Command->CommandText = (_bstr_t) strSQL.GetBuffer(0);
  244. long state = m_Recordset->GetState();
  245. if(state)
  246. {
  247. m_Recordset->Close();
  248. }
  249. m_Recordset = m_Command->Execute(&vra, vt1, adCmdText);
  250. long recordCount = m_Recordset->GetRecordCount();
  251. if(recordCount)
  252. {
  253. m_Recordset->MoveFirst();
  254. _variant_t Value = m_Recordset->GetCollect((long)0);
  255. COleCurrency var_currency;
  256. if(Value.vt == VT_CY)
  257. {
  258. var_currency = Value.cyVal;
  259. strTotalIn = var_currency.Format(0);
  260. }
  262. }
  263. if(enDate == order)
  264. {
  265. strCondtionSQL.Format("where MoneyIncome.InDate between #%s# and #%s# order by MoneyIncome.InDate asc", strStartTime, strEndTime);
  266. }
  267. CString strSearchSQL;
  268. strSearchSQL.Format("select MoneyIncome.id as 编号, MoneyIncome.InMoney as 金额, ClassInfo.classremark as 类别 , MoneyIncome.InDate as 日期, MoneyIncome.operator as 操作人 , MoneyIncome.remark as 备注 from MoneyIncome inner join ClassInfo on ClassInfo.classid = MoneyIncome.InClass ");
  269. strSQL = strSearchSQL + strCondtionSQL;
  270. m_Command->CommandText = (_bstr_t) strSQL.GetBuffer(0);
  271. state = m_Recordset->GetState();
  272. if(state)
  273. {
  274. m_Recordset->Close();
  275. }
  276. m_Recordset = m_Command->Execute(&vra, vt1, adCmdText);
  277. recordCount = m_Recordset->GetRecordCount();
  279. DBGrid.setRecordSet(m_Recordset);
  280. DBGrid.Reflesh();
  282. }catch(_com_error &e)
  283. {
  284. _bstr_t bstrSource(e.Source());
  285.         _bstr_t bstrDescription(e.Description());
  286.         TRACE("Exception throw for classes generated by #import");
  287.         TRACE("tCode=%08lxn", e.Error);
  288.         TRACE("tCode meaning = %sn", e.ErrorMessage);
  289.         TRACE("tSource = %sn", (LPCTSTR)bstrSource);
  290.         TRACE("tDescription = %sn", (LPCTSTR)bstrDescription);
  291. }
  292. }
  293. //-------------------------------------------------------------------------------------------------
  295. void    CDBOperator::ReOrderFinanceIn(CString& strStartTime, 
  296. CString& strEndTime, 
  297. CFinanceDBGrid& DBGrid, 
  298. CString& strTotalIn, 
  299. CString& strTitle, 
  300. CString& strOder)
  301. {
  302. try
  303. {
  304. CString strSQL;
  305. CString strCondtionSQL;
  306. strCondtionSQL.Format("where MoneyIncome.InDate between #%s# and #%s#", strStartTime, strEndTime);
  308. _variant_t vra;
  309. VARIANT *vt1 = NULL;
  311. strSQL.Format("select SUM(MoneyIncome.InMoney) from MoneyIncome %s", strCondtionSQL);
  312. m_Command->CommandText = (_bstr_t) strSQL.GetBuffer(0);
  313. long state = m_Recordset->GetState();
  314. if(state)
  315. {
  316. m_Recordset->Close();
  317. }
  318. m_Recordset = m_Command->Execute(&vra, vt1, adCmdText);
  319. long recordCount = m_Recordset->GetRecordCount();
  320. if(recordCount)
  321. {
  322. m_Recordset->MoveFirst();
  323. _variant_t Value = m_Recordset->GetCollect((long)0);
  324. COleCurrency var_currency;
  325. if(Value.vt == VT_CY)
  326. {
  327. var_currency = Value.cyVal;
  328. strTotalIn = var_currency.Format(0);
  329. }
  331. }
  332. CString strOderTitle;
  333. if(strTitle.Compare("金额") == 0)
  334. {
  335. strOderTitle = "MoneyIncome.InMoney";
  336. }
  337. if(strTitle.Compare("类别") == 0)
  338. {
  339. strOderTitle = "ClassInfo.classremark";
  340. }
  341. if(strTitle.Compare("日期") == 0)
  342. {
  343. strOderTitle = "MoneyIncome.InDate";
  344. }
  345. if(strTitle.Compare("操作人") == 0)
  346. {
  347. strOderTitle = "MoneyIncome.operator";
  348. }
  351. strCondtionSQL.Format("where MoneyIncome.InDate between #%s# and #%s# order by %s %s", strStartTime, strEndTime, strOderTitle, strOder);
  353. CString strSearchSQL;
  354. strSearchSQL.Format("select MoneyIncome.id as 编号, MoneyIncome.InMoney as 金额, ClassInfo.classremark as 类别 , MoneyIncome.InDate as 日期, MoneyIncome.operator as 操作人 , MoneyIncome.remark as 备注 from MoneyIncome inner join ClassInfo on ClassInfo.classid = MoneyIncome.InClass ");
  355. strSQL = strSearchSQL + strCondtionSQL;
  356. m_Command->CommandText = (_bstr_t) strSQL.GetBuffer(0);
  357. state = m_Recordset->GetState();
  358. if(state)
  359. {
  360. m_Recordset->Close();
  361. }
  362. m_Recordset = m_Command->Execute(&vra, vt1, adCmdText);
  363. recordCount = m_Recordset->GetRecordCount();
  365. DBGrid.setRecordSet(m_Recordset);
  366. DBGrid.Reflesh();
  368. }catch(_com_error &e)
  369. {
  370. _bstr_t bstrSource(e.Source());
  371.         _bstr_t bstrDescription(e.Description());
  372.         TRACE("Exception throw for classes generated by #import");
  373.         TRACE("tCode=%08lxn", e.Error);
  374.         TRACE("tCode meaning = %sn", e.ErrorMessage);
  375.         TRACE("tSource = %sn", (LPCTSTR)bstrSource);
  376.         TRACE("tDescription = %sn", (LPCTSTR)bstrDescription);
  377. }
  379. }
  381. //-------------------------------------------------------------------------------------------------
  383. void    CDBOperator::addFinanceIn(CString& strMoney, CString& strClass, 
  384.  CString& strDate, CString& strRemark)
  385. {
  386. try
  387. {
  388. CString strUser;
  389. strUser = gSysStatus.getUserName();
  390. CString strSQL;
  391. strSQL.Format("INSERT INTO MoneyIncome (InMoney,InClass,InDate,operator,remark) VALUES (%s,%s,'%s','%s','%s')",
  392. strMoney,  strClass, strDate, strUser, strRemark);
  394. m_Command->CommandText = (_bstr_t) strSQL.GetBuffer(0);
  396. _variant_t vra;
  397. VARIANT *vt1 = NULL;
  398. m_Command->Execute(&vra, vt1, adCmdText);
  399. AfxMessageBox("成功添加一笔收入");
  400. }catch(_com_error &e)
  401. {
  402. _bstr_t bstrSource(e.Source());
  403.         _bstr_t bstrDescription(e.Description());
  404.         TRACE("Exception throw for classes generated by #import");
  405.         TRACE("tCode=%08lxn", e.Error);
  406.         TRACE("tCode meaning = %sn", e.ErrorMessage);
  407.         TRACE("tSource = %sn", (LPCTSTR)bstrSource);
  408.         TRACE("tDescription = %sn", (LPCTSTR)bstrDescription);
  409. }
  410. }
  411. //-------------------------------------------------------------------------------------------------
  413. void    CDBOperator::addInClass(CString& strClass)
  414. {
  415. try
  416. {
  417. if(strClass.IsEmpty() || getClassID(strClass) > -1)
  418. {
  419. AfxMessageBox("该类别已经存在或为空, 无法添加!");
  420. return;
  421. }
  422. int iClassID;
  423. CString strSQL;
  424. strSQL.Format("select max(classid) from classinfo");
  425. m_Command->CommandText = (_bstr_t) strSQL.GetBuffer(0);
  427. _variant_t vra;
  428. VARIANT *vt1 = NULL;
  429. m_Recordset = m_Command->Execute(&vra, vt1, adCmdText);
  430. if(!m_Recordset->adoEOF)
  431. {
  432. _variant_t Value = m_Recordset->GetCollect((long)0);
  433. iClassID = (long)Value;
  434. }
  435. iClassID += 1;
  437. strSQL.Format("insert into classinfo(classid, classremark) values(%d, '%s')", iClassID, strClass.GetBuffer(0));
  438. m_Command->CommandText = (_bstr_t) strSQL.GetBuffer(0);
  439. m_Command->Execute(&vra, vt1, adCmdText);
  442. }catch(_com_error &e)
  443. {
  444. _bstr_t bstrSource(e.Source());
  445.         _bstr_t bstrDescription(e.Description());
  446.         TRACE("Exception throw for classes generated by #import");
  447.         TRACE("tCode=%08lxn", e.Error);
  448.         TRACE("tCode meaning = %sn", e.ErrorMessage);
  449.         TRACE("tSource = %sn", (LPCTSTR)bstrSource);
  450.         TRACE("tDescription = %sn", (LPCTSTR)bstrDescription);
  451. }
  452. AfxMessageBox("成功添加新的收入类别");
  453. }
  454. //-------------------------------------------------------------------------------------------------
  456. void    CDBOperator::addOutClass(CString& strClass)
  457. {
  458. try
  459. {
  460. if(strClass.IsEmpty() || getOutClassID(strClass) > -1)
  461. {
  462. AfxMessageBox("该类别已经存在或为空, 无法添加!");
  463. return;
  464. }
  465. int iClassID;
  466. CString strSQL;
  467. strSQL.Format("select max(classid) from OutClass");
  468. m_Command->CommandText = (_bstr_t) strSQL.GetBuffer(0);
  470. _variant_t vra;
  471. VARIANT *vt1 = NULL;
  472. m_Recordset = m_Command->Execute(&vra, vt1, adCmdText);
  473. if(!m_Recordset->adoEOF)
  474. {
  475. _variant_t Value = m_Recordset->GetCollect((long)0);
  476. iClassID = (long)Value;
  477. }
  478. iClassID += 1;
  480. strSQL.Format("insert into OutClass(classid, remark) values(%d, '%s')", iClassID, strClass.GetBuffer(0));
  481. m_Command->CommandText = (_bstr_t) strSQL.GetBuffer(0);
  482. m_Command->Execute(&vra, vt1, adCmdText);
  485. }catch(_com_error &e)
  486. {
  487. _bstr_t bstrSource(e.Source());
  488.         _bstr_t bstrDescription(e.Description());
  489.         TRACE("Exception throw for classes generated by #import");
  490.         TRACE("tCode=%08lxn", e.Error);
  491.         TRACE("tCode meaning = %sn", e.ErrorMessage);
  492.         TRACE("tSource = %sn", (LPCTSTR)bstrSource);
  493.         TRACE("tDescription = %sn", (LPCTSTR)bstrDescription);
  494. }
  495. AfxMessageBox("成功添加新的支出类别");
  496. }
  497. //-------------------------------------------------------------------------------------------------
  499. int     CDBOperator::getClassID(CString& strClass)
  500. {
  501. int iClassID = -1;
  502. try
  503. {
  504. CString strSQL;
  505. strSQL.Format("select classid from classinfo where classremark = '%s'", strClass.GetBuffer(0));
  506. m_Command->CommandText = (_bstr_t) strSQL.GetBuffer(0);
  508. _variant_t vra;
  509. VARIANT *vt1 = NULL;
  510. m_Recordset = m_Command->Execute(&vra, vt1, adCmdText);
  511. if(!m_Recordset->adoEOF)
  512. {
  513. _variant_t Value = m_Recordset->GetCollect((long)0);
  514. iClassID = (long)Value;
  515. }
  516. return iClassID;
  517. }catch(_com_error &e)
  518. {
  519. _bstr_t bstrSource(e.Source());
  520.         _bstr_t bstrDescription(e.Description());
  521.         TRACE("Exception throw for classes generated by #import");
  522.         TRACE("tCode=%08lxn", e.Error);
  523.         TRACE("tCode meaning = %sn", e.ErrorMessage);
  524.         TRACE("tSource = %sn", (LPCTSTR)bstrSource);
  525.         TRACE("tDescription = %sn", (LPCTSTR)bstrDescription);
  526. }
  527. return iClassID;
  528. }
  529. //-------------------------------------------------------------------------------------------------
  531. void CDBOperator::getMoneyInClassInfo(CSysDataStruct::CClassInfo& ClassInfo)
  532. {
  533. try
  534. {
  535. _variant_t vra;
  536. VARIANT *vt1 = NULL;
  538. CString strSQL;
  539. strSQL.Format("select classid, classremark from ClassInfo");
  540. m_Command->CommandText = (_bstr_t) strSQL.GetBuffer(0);
  541. long state = m_Recordset->GetState();
  542. if(state)
  543. {
  544. m_Recordset->Close();
  545. }
  546. m_Recordset = m_Command->Execute(&vra, vt1, adCmdText);
  547. long recordCount = m_Recordset->GetRecordCount();
  548. ClassInfo.m_iClassNum = 0;
  549. if(recordCount)
  550. {
  551. m_Recordset->MoveFirst();
  552. while(!m_Recordset->adoEOF)
  553. {
  555. _variant_t Value = m_Recordset->GetCollect((long)1);
  556. if(Value.vt ==  VT_BSTR)
  557. {
  558. ClassInfo.m_Classes[ClassInfo.m_iClassNum] = CString(Value.bstrVal);
  559. }
  561. ClassInfo.m_iClassNum++;
  563. m_Recordset->MoveNext();
  564. }
  566. }
  568. }catch(_com_error &e)
  569. {
  570. _bstr_t bstrSource(e.Source());
  571.         _bstr_t bstrDescription(e.Description());
  572.         TRACE("Exception throw for classes generated by #import");
  573.         TRACE("tCode=%08lxn", e.Error);
  574.         TRACE("tCode meaning = %sn", e.ErrorMessage);
  575.         TRACE("tSource = %sn", (LPCTSTR)bstrSource);
  576.         TRACE("tDescription = %sn", (LPCTSTR)bstrDescription);
  577. }
  579. }
  580. //-------------------------------------------------------------------------------------------------
  582. void CDBOperator::getInClassInfo(CListCtrl* pdbGrid)
  583. {
  584. try
  585. {
  586. CString strSQL = "Select * from ClassInfo";
  587. m_Command->CommandText = (_bstr_t) strSQL.GetBuffer(0);
  589. _variant_t vra;
  590. VARIANT *vt1 = NULL;
  591. long state = m_Recordset->GetState();
  592. if(state)
  593. {
  594. m_Recordset->Close();
  595. }
  596. m_Recordset = m_Command->Execute(&vra, vt1, adCmdText);
  597. long recordCount = m_Recordset->GetRecordCount();
  598. if(recordCount)
  599. {
  600. int iColumNum = pdbGrid->GetHeaderCtrl()->GetItemCount();
  601.             RECT rcWindow;
  602. pdbGrid->GetClientRect(&rcWindow);
  603. for(int i = 0; i < iColumNum; i++)
  604. {
  605. pdbGrid->DeleteColumn(i);
  606. }
  607.             int iListWidth = (rcWindow.right - rcWindow.left);
  608. LONG lStyle = pdbGrid->SendMessage(LVM_GETEXTENDEDLISTVIEWSTYLE);
  609. lStyle |= LVS_EX_FULLROWSELECT | LVS_EX_GRIDLINES | LVS_EX_HEADERDRAGDROP;
  610. pdbGrid->SendMessage(LVM_SETEXTENDEDLISTVIEWSTYLE, 0, (LPARAM)lStyle);
  612. LV_COLUMN lvc;
  613. lvc.mask = LVCF_TEXT | LVCF_SUBITEM | LVCF_WIDTH /*| LVCF_FMT*/;
  615. lvc.iSubItem = 0;
  616. lvc.pszText = "编号";
  617. lvc.cx = iListWidth / 5;
  618. pdbGrid->InsertColumn(0,&lvc);
  620. lvc.iSubItem = 1;
  621. lvc.pszText = "类别";
  622. lvc.cx = iListWidth - iListWidth / 5;
  623. pdbGrid->InsertColumn(1,&lvc);
  626. pdbGrid->DeleteAllItems();
  630. int iPos = -1;
  632. m_Recordset->MoveFirst();
  633. while(!m_Recordset->adoEOF)
  634. {
  636. LV_ITEM lvitem;
  637. lvitem.mask = LVIF_TEXT | LVIF_IMAGE | LVIF_STATE;
  638. lvitem.state = 0;      
  639. lvitem.stateMask = 0; 
  641. CString strTemp;
  642. _variant_t Value;
  645. lvitem.iItem = ++iPos;
  646. lvitem.iSubItem = 0;
  648. Value = m_Recordset->GetCollect("classid");
  649. int iClassid = (int)Value.lVal;
  650. strTemp.Format("%d", iClassid);
  651. lvitem.pszText = strTemp.GetBuffer(0);
  652. pdbGrid->InsertItem(&lvitem);
  654. Value = m_Recordset->GetCollect("classremark");
  655. strTemp = Value.bstrVal;
  656. pdbGrid->SetItemText(iPos, 1, (LPCTSTR)strTemp.GetBuffer(0));
  658. m_Recordset->MoveNext();
  659. }
  661. }
  664. }catch(_com_error &e)
  665. {
  666. _bstr_t bstrSource(e.Source());
  667.         _bstr_t bstrDescription(e.Description());
  668.         TRACE("Exception throw for classes generated by #import");
  669.         TRACE("tCode=%08lxn", e.Error);
  670.         TRACE("tCode meaning = %sn", e.ErrorMessage);
  671.         TRACE("tSource = %sn", (LPCTSTR)bstrSource);
  672.         TRACE("tDescription = %sn", (LPCTSTR)bstrDescription);
  673. }
  675. }
  676. //-------------------------------------------------------------------------------------------------
  678. void CDBOperator::selectFinanceOut(CString& strStartTime, 
  679.   CString& strEndTime, 
  680.   CFinanceDBGrid& DBGrid, 
  681.   CString& strTotalOut, 
  682.   SELECTORDER order)
  683. {
  684. try
  685. {
  686. CString strSQL;
  687. CString strCondtionSQL;
  688. strCondtionSQL.Format("where MoneyOut.Outdate between #%s# and #%s# ", strStartTime, strEndTime);
  690. _variant_t vra;
  691. VARIANT *vt1 = NULL;
  692. long recordCount;
  694. strSQL.Format("select SUM(MoneyOut.OutMoney) from MoneyOut %s", strCondtionSQL);
  695. m_Command->CommandText = (_bstr_t) strSQL.GetBuffer(0);
  696. long state = m_Recordset->GetState();
  697. if(state)
  698. {
  699. m_Recordset->Close();
  700. }
  701. m_Recordset = m_Command->Execute(&vra, vt1, adCmdText);
  702. recordCount = m_Recordset->GetRecordCount();
  703. if(recordCount)
  704. {
  705. m_Recordset->MoveFirst();
  706. _variant_t Value = m_Recordset->GetCollect((long)0);
  707. COleCurrency var_currency;
  708. if(Value.vt == VT_CY)
  709. {
  710. var_currency = Value.cyVal;
  711. strTotalOut = var_currency.Format(0);
  712. }
  714. }
  716. if( enDate == order)
  717. strCondtionSQL.Format("where MoneyOut.Outdate between #%s# and #%s# order by  MoneyOut.Outdate asc", strStartTime, strEndTime);
  718. if( enMoney == order)
  719. strCondtionSQL.Format("where MoneyOut.Outdate between #%s# and #%s# order by  MoneyOut.OutMoney desc", strStartTime, strEndTime);
  720. CString strSearchSQL;
  721. strSearchSQL.Format("select MoneyOut.id as 编号, MoneyOut.OutMoney as 金额, OutClass.remark as 类别 ,
  722.  MoneyOut.remark as 备注, MoneyOut.Outdate as 日期 , MoneyOut.operator as 操作人
  723.  from MoneyOut inner join OutClass on OutClass.classid = MoneyOut.OutClass ");
  725.  /*strSearchSQL.Format("select MoneyOut.id as 编号, MoneyOut.OutMoney as 金额, MoneyOut.Outdate as 日期, MoneyOut.operator as 操作人 , MoneyOut.remark as 备注 
  726.  from MoneyOut ");*/
  728. strSQL = strSearchSQL + strCondtionSQL;
  729. m_Command->CommandText = (_bstr_t) strSQL.GetBuffer(0);
  730. state = m_Recordset->GetState();
  731. if(state)
  732. {
  733. m_Recordset->Close();
  734. }
  735. m_Recordset = m_Command->Execute(&vra, vt1, adCmdText);
  736. recordCount = m_Recordset->GetRecordCount();
  738. DBGrid.setRecordSet(m_Recordset);
  739. DBGrid.Reflesh();
  742. }catch(_com_error &e)
  743. {
  744. _bstr_t bstrSource(e.Source());
  745.         _bstr_t bstrDescription(e.Description());
  746.         TRACE("Exception throw for classes generated by #import");
  747.         TRACE("tCode=%08lxn", e.Error);
  748.         TRACE("tCode meaning = %sn", e.ErrorMessage);
  749.         TRACE("tSource = %sn", (LPCTSTR)bstrSource);
  750.         TRACE("tDescription = %sn", (LPCTSTR)bstrDescription);
  751. }
  752. }
  754. //-------------------------------------------------------------------------------------------------
  756. void    CDBOperator::ReOrderFinanceOut(CString& strStartTime, 
  757.    CString& strEndTime, 
  758.    CFinanceDBGrid& DBGrid, 
  759.    CString& strTotalOut, 
  760.    CString& strTitle, 
  761.    CString& strOder)
  762. {
  763. try
  764. {
  765. CString strSQL;
  766. CString strCondtionSQL;
  767. strCondtionSQL.Format("where MoneyOut.Outdate between #%s# and #%s# ", strStartTime, strEndTime);
  769. _variant_t vra;
  770. VARIANT *vt1 = NULL;
  771. long recordCount;
  773. strSQL.Format("select SUM(MoneyOut.OutMoney) from MoneyOut %s", strCondtionSQL);
  774. m_Command->CommandText = (_bstr_t) strSQL.GetBuffer(0);
  775. long state = m_Recordset->GetState();
  776. if(state)
  777. {
  778. m_Recordset->Close();
  779. }
  780. m_Recordset = m_Command->Execute(&vra, vt1, adCmdText);
  781. recordCount = m_Recordset->GetRecordCount();
  782. if(recordCount)
  783. {
  784. m_Recordset->MoveFirst();
  785. _variant_t Value = m_Recordset->GetCollect((long)0);
  786. COleCurrency var_currency;
  787. if(Value.vt == VT_CY)
  788. {
  789. var_currency = Value.cyVal;
  790. strTotalOut = var_currency.Format(0);
  791. }
  793. }
  795. CString strOrderTitle;
  796. if(strTitle.Compare("金额") == 0)
  797. {
  798. strOrderTitle.Format("%s", "MoneyOut.OutMoney");
  799. }
  800. if(strTitle.Compare("类别") == 0)
  801. {
  802. strOrderTitle.Format("%s", "OutClass.remark");
  803. }
  804. if(strTitle.Compare("日期") == 0)
  805. {
  806. strOrderTitle.Format("%s", "MoneyOut.Outdate");
  807. }
  808. if(strTitle.Compare("操作人") == 0)
  809. {
  810. strOrderTitle.Format("%s", "MoneyOut.operator");
  811. }
  813. strCondtionSQL.Format("where MoneyOut.Outdate between #%s# and #%s# order by  %s %s", strStartTime, strEndTime, strOrderTitle, strOder);
  815. CString strSearchSQL;
  816. strSearchSQL.Format("select MoneyOut.id as 编号, MoneyOut.OutMoney as 金额, OutClass.remark as 类别 ,
  817.  MoneyOut.remark as 备注, MoneyOut.Outdate as 日期 , MoneyOut.operator as 操作人
  818.  from MoneyOut inner join OutClass on OutClass.classid = MoneyOut.OutClass ");
  820.  /*strSearchSQL.Format("select MoneyOut.id as 编号, MoneyOut.OutMoney as 金额, MoneyOut.Outdate as 日期, MoneyOut.operator as 操作人 , MoneyOut.remark as 备注 
  821.  from MoneyOut ");*/
  823. strSQL = strSearchSQL + strCondtionSQL;
  824. m_Command->CommandText = (_bstr_t) strSQL.GetBuffer(0);
  825. state = m_Recordset->GetState();
  826. if(state)
  827. {
  828. m_Recordset->Close();
  829. }
  830. m_Recordset = m_Command->Execute(&vra, vt1, adCmdText);
  831. recordCount = m_Recordset->GetRecordCount();
  833. DBGrid.setRecordSet(m_Recordset);
  834. DBGrid.Reflesh();
  837. }catch(_com_error &e)
  838. {
  839. _bstr_t bstrSource(e.Source());
  840.         _bstr_t bstrDescription(e.Description());
  841.         TRACE("Exception throw for classes generated by #import");
  842.         TRACE("tCode=%08lxn", e.Error);
  843.         TRACE("tCode meaning = %sn", e.ErrorMessage);
  844.         TRACE("tSource = %sn", (LPCTSTR)bstrSource);
  845.         TRACE("tDescription = %sn", (LPCTSTR)bstrDescription);
  846. }
  847. }
  848. //支出相关函数
  849. //-------------------------------------------------------------------------------------------------
  851. int     CDBOperator::getOutClassID(CString& strClass)
  852. {
  853. int iClassID = -1;
  854. try
  855. {
  856. CString strSQL;
  857. strSQL.Format("select classid from OutClass where remark = '%s'", strClass.GetBuffer(0));
  858. m_Command->CommandText = (_bstr_t) strSQL.GetBuffer(0);
  860. _variant_t vra;
  861. VARIANT *vt1 = NULL;
  862. m_Recordset = m_Command->Execute(&vra, vt1, adCmdText);
  863. if(!m_Recordset->adoEOF)
  864. {
  865. _variant_t Value = m_Recordset->GetCollect((long)0);
  866. iClassID = (long)Value;
  867. }
  868. return iClassID;
  869. }catch(_com_error &e)
  870. {
  871. _bstr_t bstrSource(e.Source());
  872.         _bstr_t bstrDescription(e.Description());
  873.         TRACE("Exception throw for classes generated by #import");
  874.         TRACE("tCode=%08lxn", e.Error);
  875.         TRACE("tCode meaning = %sn", e.ErrorMessage);
  876.         TRACE("tSource = %sn", (LPCTSTR)bstrSource);
  877.         TRACE("tDescription = %sn", (LPCTSTR)bstrDescription);
  878. }
  879. return iClassID;
  880. }
  881. //-------------------------------------------------------------------------------------------------
  883. void CDBOperator::addFinanceOut(CString& strMoney, CString& strClass, CString& strDate, CString& strRemark)
  884. {
  885. try
  886. {
  887. CString strUser;
  888. strUser = gSysStatus.getUserName();
  889. CString strSQL;
  890. strSQL.Format("INSERT INTO MoneyOut (OutMoney,OutClass,Outdate,operator,remark) VALUES (%s,%s,'%s','%s','%s')",
  891. strMoney,  strClass, strDate, strUser, strRemark);
  893. m_Command->CommandText = (_bstr_t) strSQL.GetBuffer(0);
  894. _variant_t vra;
  895. VARIANT *vt1 = NULL;
  896. m_Command->Execute(&vra, vt1, adCmdText);
  897. AfxMessageBox("成功添加一笔支出");
  898. }catch(_com_error &e)
  899. {
  900. _bstr_t bstrSource(e.Source());
  901.         _bstr_t bstrDescription(e.Description());
  902.         TRACE("Exception throw for classes generated by #import");
  903.         TRACE("tCode=%08lxn", e.Error);
  904.         TRACE("tCode meaning = %sn", e.ErrorMessage);
  905.         TRACE("tSource = %sn", (LPCTSTR)bstrSource);
  906.         TRACE("tDescription = %sn", (LPCTSTR)bstrDescription);
  907. }
  908. }
  909. //-------------------------------------------------------------------------------------------------
  911. void CDBOperator::getMoneyOutClassInfo(CSysDataStruct::CClassInfo& ClassInfo)
  912. {
  913. try
  914. {
  915. _variant_t vra;
  916. VARIANT *vt1 = NULL;
  918. CString strSQL;
  919. strSQL.Format("select classid, remark from OutClass");
  920. m_Command->CommandText = (_bstr_t) strSQL.GetBuffer(0);
  921. long state = m_Recordset->GetState();
  922. if(state)
  923. {
  924. m_Recordset->Close();
  925. }
  926. m_Recordset = m_Command->Execute(&vra, vt1, adCmdText);
  927. long recordCount = m_Recordset->GetRecordCount();
  928. ClassInfo.m_iClassNum = 0;
  929. if(recordCount)
  930. {
  931. m_Recordset->MoveFirst();
  932. while(!m_Recordset->adoEOF)
  933. {
  935. _variant_t Value = m_Recordset->GetCollect((long)1);
  936. if(Value.vt ==  VT_BSTR)
  937. {
  938. ClassInfo.m_Classes[ClassInfo.m_iClassNum] = CString(Value.bstrVal);
  939. }
  941. ClassInfo.m_iClassNum++;
  943. m_Recordset->MoveNext();
  944. }
  946. }
  948. }catch(_com_error &e)
  949. {
  950. _bstr_t bstrSource(e.Source());
  951.         _bstr_t bstrDescription(e.Description());
  952.         TRACE("Exception throw for classes generated by #import");
  953.         TRACE("tCode=%08lxn", e.Error);
  954.         TRACE("tCode meaning = %sn", e.ErrorMessage);
  955.         TRACE("tSource = %sn", (LPCTSTR)bstrSource);
  956.         TRACE("tDescription = %sn", (LPCTSTR)bstrDescription);
  957. }
  958. }
  960. //-------------------------------------------------------------------------------------------------
  962. void CDBOperator::getOutClassInfo(CListCtrl* pdbGrid)
  963. {
  964. try
  965. {
  966. CString strSQL = "Select * from outclass";
  967. m_Command->CommandText = (_bstr_t) strSQL.GetBuffer(0);
  969. _variant_t vra;
  970. VARIANT *vt1 = NULL;
  971. long state = m_Recordset->GetState();
  972. if(state)
  973. {
  974. m_Recordset->Close();
  975. }
  976. m_Recordset = m_Command->Execute(&vra, vt1, adCmdText);
  977. long recordCount = m_Recordset->GetRecordCount();
  978. if(recordCount)
  979. {
  980. int iColumNum = pdbGrid->GetHeaderCtrl()->GetItemCount();
  981.             RECT rcWindow;
  982. pdbGrid->GetClientRect(&rcWindow);
  983. for(int i = 0; i < iColumNum; i++)
  984. {
  985. pdbGrid->DeleteColumn(i);
  986. }
  987.             int iListWidth = (rcWindow.right - rcWindow.left);
  988. LONG lStyle = pdbGrid->SendMessage(LVM_GETEXTENDEDLISTVIEWSTYLE);
  989. lStyle |= LVS_EX_FULLROWSELECT | LVS_EX_GRIDLINES | LVS_EX_HEADERDRAGDROP;
  990. pdbGrid->SendMessage(LVM_SETEXTENDEDLISTVIEWSTYLE, 0, (LPARAM)lStyle);
  992. LV_COLUMN lvc;
  993. lvc.mask = LVCF_TEXT | LVCF_SUBITEM | LVCF_WIDTH /*| LVCF_FMT*/;
  995. lvc.iSubItem = 0;
  996. lvc.pszText = "编号";
  997. lvc.cx = iListWidth / 5;
  998. pdbGrid->InsertColumn(0,&lvc);
  1000. lvc.iSubItem = 1;
  1001. lvc.pszText = "类别";
  1002. lvc.cx = iListWidth - iListWidth / 5;
  1003. pdbGrid->InsertColumn(1,&lvc);
  1006. pdbGrid->DeleteAllItems();
  1010. int iPos = -1;
  1012. m_Recordset->MoveFirst();
  1013. while(!m_Recordset->adoEOF)
  1014. {
  1016. LV_ITEM lvitem;
  1017. lvitem.mask = LVIF_TEXT | LVIF_IMAGE | LVIF_STATE;
  1018. lvitem.state = 0;      
  1019. lvitem.stateMask = 0; 
  1021. CString strTemp;
  1022. _variant_t Value;
  1025. lvitem.iItem = ++iPos;
  1026. lvitem.iSubItem = 0;
  1028. Value = m_Recordset->GetCollect("classid");
  1029. int iClassid = (int)Value.lVal;
  1030. strTemp.Format("%d", iClassid);
  1031. lvitem.pszText = strTemp.GetBuffer(0);
  1032. pdbGrid->InsertItem(&lvitem);
  1034. Value = m_Recordset->GetCollect("remark");
  1035. strTemp = Value.bstrVal;
  1036. pdbGrid->SetItemText(iPos, 1, (LPCTSTR)strTemp.GetBuffer(0));
  1038. m_Recordset->MoveNext();
  1039. }
  1041. }
  1044. }catch(_com_error &e)
  1045. {
  1046. _bstr_t bstrSource(e.Source());
  1047.         _bstr_t bstrDescription(e.Description());
  1048.         TRACE("Exception throw for classes generated by #import");
  1049.         TRACE("tCode=%08lxn", e.Error);
  1050.         TRACE("tCode meaning = %sn", e.ErrorMessage);
  1051.         TRACE("tSource = %sn", (LPCTSTR)bstrSource);
  1052.         TRACE("tDescription = %sn", (LPCTSTR)bstrDescription);
  1053. }
  1054. }
  1055. //-------------------------------------------------------------------------------------------------
  1057. void CDBOperator::DeleteFinanceIn(int iID)
  1058. {
  1059. try
  1060. {
  1061. CString strSQL;
  1062. _variant_t vra;
  1063. VARIANT *vt1 = NULL;
  1064. strSQL.Format("delete from MoneyIncome where [id]=%d", iID);
  1065. m_Command->CommandText = (_bstr_t) strSQL.GetBuffer(0);
  1066. m_Command->Execute(&vra, vt1, adCmdText);
  1068. AfxMessageBox("成功删除记录");
  1071. }catch(_com_error &e)
  1072. {
  1073. _bstr_t bstrSource(e.Source());
  1074.         _bstr_t bstrDescription(e.Description());
  1075.         TRACE("Exception throw for classes generated by #import");
  1076.         TRACE("tCode=%08lxn", e.Error);
  1077.         TRACE("tCode meaning = %sn", e.ErrorMessage);
  1078.         TRACE("tSource = %sn", (LPCTSTR)bstrSource);
  1079.         TRACE("tDescription = %sn", (LPCTSTR)bstrDescription);
  1080. }
  1081. }
  1082. //-------------------------------------------------------------------------------------------------
  1084. void CDBOperator::DeleteFinanceOut(int iID)
  1085. {
  1086. try
  1087. {
  1088. CString strSQL;
  1089. _variant_t vra;
  1090. VARIANT *vt1 = NULL;
  1091. strSQL.Format("delete from MoneyOut where [id]=%d", iID);
  1092. m_Command->CommandText = (_bstr_t) strSQL.GetBuffer(0);
  1093. m_Command->Execute(&vra, vt1, adCmdText);
  1095. AfxMessageBox("成功删除记录");
  1098. }catch(_com_error &e)
  1099. {
  1100. _bstr_t bstrSource(e.Source());
  1101.         _bstr_t bstrDescription(e.Description());
  1102.         TRACE("Exception throw for classes generated by #import");
  1103.         TRACE("tCode=%08lxn", e.Error);
  1104.         TRACE("tCode meaning = %sn", e.ErrorMessage);
  1105.         TRACE("tSource = %sn", (LPCTSTR)bstrSource);
  1106.         TRACE("tDescription = %sn", (LPCTSTR)bstrDescription);
  1107. }
  1108. }
  1109. //-------------------------------------------------------------------------------------------------
  1111. void    CDBOperator::UpdateRecord(int iID, CString& strSum, CString& strClass, 
  1112.  CString& strDate, CString& strRemark, bool bIsMoneyOut)
  1113. {
  1114. CString strSQL;
  1115. _variant_t vra;
  1116. VARIANT *vt1 = NULL;
  1118. if(bIsMoneyOut)
  1119. {
  1120. strSQL.Format("select classid from outclass where remark='%s'", strClass);
  1121. m_Command->CommandText = (_bstr_t) strSQL.GetBuffer(0);
  1122. long state = m_Recordset->GetState();
  1123. if(state)
  1124. {
  1125. m_Recordset->Close();
  1126. }
  1127. m_Recordset = m_Command->Execute(&vra, vt1, adCmdText);
  1128. int recordCount = m_Recordset->GetRecordCount();
  1129. if(recordCount < 1)
  1130. {
  1131. ::MessageBox(NULL, "指定的类别不存在", "错误", MB_OK);
  1132. return;
  1133. }
  1134. int iClassID;
  1135. m_Recordset->MoveFirst();
  1136. _variant_t Value = m_Recordset->GetCollect((long)0);
  1137. iClassID = (long)Value;
  1141. strSQL.Format("update moneyout  set outmoney=%s, OutClass=%d, outdate='%s', remark='%s' where id = %d", 
  1142.           strSum, 
  1143.   iClassID,
  1144.   strDate,
  1145.   strRemark,
  1146.   iID);
  1148. m_Command->CommandText = (_bstr_t) strSQL.GetBuffer(0);
  1149. m_Command->Execute(&vra, vt1, adCmdText);
  1150. }
  1151. else
  1152. {
  1153. strSQL.Format("select classid from ClassInfo where classremark='%s'", strClass);
  1154. m_Command->CommandText = (_bstr_t) strSQL.GetBuffer(0);
  1155. long state = m_Recordset->GetState();
  1156. if(state)
  1157. {
  1158. m_Recordset->Close();
  1159. }
  1160. m_Recordset = m_Command->Execute(&vra, vt1, adCmdText);
  1161. int recordCount = m_Recordset->GetRecordCount();
  1162. if(recordCount < 1)
  1163. {
  1164. ::MessageBox(NULL, "指定的类别不存在", "错误", MB_OK);
  1165. return;
  1166. }
  1167. int iClassID;
  1168. m_Recordset->MoveFirst();
  1169. _variant_t Value = m_Recordset->GetCollect((long)0);
  1170. iClassID = (long)Value;
  1172. strSQL.Format("update MoneyIncome  set InMoney=%s, InClass=%d, InDate='%s', remark='%s' where id = %d", 
  1173.           strSum, 
  1174.   iClassID,
  1175.   strDate,
  1176.   strRemark,
  1177.   iID);
  1179. m_Command->CommandText = (_bstr_t) strSQL.GetBuffer(0);
  1180. m_Command->Execute(&vra, vt1, adCmdText);
  1182. }
  1185. ::MessageBox(NULL, "成功更改指定记录", "提示", MB_OK);
  1186. }
  1187. //-------------------------------------------------------------------------------------------------
  1189. void CDBOperator::getBalance(CString& strStartTime, 
  1190. CString& strEndTime, 
  1191. CTreeCtrl& treeBalance, 
  1192. CString& strTotalIn,
  1193. CString& strTotalOut)
  1194. {
  1195. //获取收入总额
  1196. strTotalIn = "0";
  1197. strTotalOut = "0";
  1198. CString strSQL;
  1199. CString strCondtionSQL;
  1200. strCondtionSQL.Format("where MoneyIncome.InDate between #%s# and #%s#", strStartTime, strEndTime);
  1201. _variant_t vra;
  1202. VARIANT *vt1 = NULL;
  1204. strSQL.Format("select SUM(MoneyIncome.InMoney) from MoneyIncome %s", strCondtionSQL);
  1205. m_Command->CommandText = (_bstr_t) strSQL.GetBuffer(0);
  1206. long state = m_Recordset->GetState();
  1207. if(state)
  1208. {
  1209. m_Recordset->Close();
  1210. }
  1211. m_Recordset = m_Command->Execute(&vra, vt1, adCmdText);
  1212. long recordCount = m_Recordset->GetRecordCount();
  1213. if(recordCount)
  1214. {
  1215. m_Recordset->MoveFirst();
  1216. _variant_t Value = m_Recordset->GetCollect((long)0);
  1217. COleCurrency var_currency;
  1218. if(Value.vt == VT_CY)
  1219. {
  1220. var_currency = Value.cyVal;
  1221. strTotalIn = var_currency.Format(0);
  1222. }
  1224. }
  1225. //获取支出总额
  1226. strCondtionSQL.Format("where MoneyOut.Outdate between #%s# and #%s#", strStartTime, strEndTime);
  1228. strSQL.Format("select SUM(MoneyOut.OutMoney) from MoneyOut %s", strCondtionSQL);
  1229. m_Command->CommandText = (_bstr_t) strSQL.GetBuffer(0);
  1230. state = m_Recordset->GetState();
  1231. if(state)
  1232. {
  1233. m_Recordset->Close();
  1234. }
  1235. m_Recordset = m_Command->Execute(&vra, vt1, adCmdText);
  1236. recordCount = m_Recordset->GetRecordCount();
  1237. if(recordCount)
  1238. {
  1239. m_Recordset->MoveFirst();
  1240. _variant_t Value = m_Recordset->GetCollect((long)0);
  1241. COleCurrency var_currency;
  1242. if(Value.vt == VT_CY)
  1243. {
  1244. var_currency = Value.cyVal;
  1245. strTotalOut = var_currency.Format(0);
  1246. }
  1248. }
  1249. }
  1250. //-------------------------------------------------------------------------------------------------
  1252. void    CDBOperator::getMoneyInClassTotal(CString& strStartTime, CString& strEndTime, CSysDataStruct::CClassInfo& ClassInfo)
  1253. {
  1254. getMoneyInClassInfo(ClassInfo);
  1255. for(int iClass = 0; iClass < ClassInfo.m_iClassNum; iClass++)
  1256. {
  1257. CString strSQL;
  1258. CString strCondtionSQL;
  1259. CString strTotalIn = "0";
  1260. strCondtionSQL.Format("where MoneyIncome.InDate between #%s# and #%s# and MoneyIncome.InClass=%d", strStartTime, strEndTime, iClass);
  1261. _variant_t vra;
  1262. VARIANT *vt1 = NULL;
  1264. strSQL.Format("select SUM(MoneyIncome.InMoney) from MoneyIncome %s", strCondtionSQL);
  1265. m_Command->CommandText = (_bstr_t) strSQL.GetBuffer(0);
  1266. long state = m_Recordset->GetState();
  1267. if(state)
  1268. {
  1269. m_Recordset->Close();
  1270. }
  1271. m_Recordset = m_Command->Execute(&vra, vt1, adCmdText);
  1272. _variant_t Value = m_Recordset->GetCollect((long)0);
  1273. COleCurrency var_currency;
  1274. if(Value.vt == VT_CY)
  1275. {
  1276. var_currency = Value.cyVal;
  1277. strTotalIn = var_currency.Format(0);
  1278. }
  1279. ClassInfo.m_dTotal[iClass] = atof(strTotalIn);
  1280. }
  1281. }
  1282. //-------------------------------------------------------------------------------------------------
  1284. void CDBOperator::getMoneyOutClassTotal(CString& strStartTime, CString& strEndTime, CSysDataStruct::CClassInfo& ClassInfo)
  1285. {
  1286. getMoneyOutClassInfo(ClassInfo);
  1287. for(int iClass = 0; iClass < ClassInfo.m_iClassNum; iClass++)
  1288. {
  1289. CString strSQL;
  1290. CString strCondtionSQL;
  1291. CString strTotalIn = "0";
  1292. strCondtionSQL.Format("where MoneyOut.Outdate between #%s# and #%s# and MoneyOut.OutClass=%d", strStartTime, strEndTime, iClass);
  1293. _variant_t vra;
  1294. VARIANT *vt1 = NULL;
  1296. strSQL.Format("select SUM(MoneyOut.OutMoney) from MoneyOut %s", strCondtionSQL);
  1297. m_Command->CommandText = (_bstr_t) strSQL.GetBuffer(0);
  1298. long state = m_Recordset->GetState();
  1299. if(state)
  1300. {
  1301. m_Recordset->Close();
  1302. }
  1303. m_Recordset = m_Command->Execute(&vra, vt1, adCmdText);
  1304. _variant_t Value = m_Recordset->GetCollect((long)0);
  1305. COleCurrency var_currency;
  1306. if(Value.vt == VT_CY)
  1307. {
  1308. var_currency = Value.cyVal;
  1309. strTotalIn = var_currency.Format(0);
  1310. }
  1311. ClassInfo.m_dTotal[iClass] = atof(strTotalIn);
  1312. }
  1313. }