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

源码开发语言/平台
当前位置：首页 > 源码/资料 > 行业应用 > 交通/航空行业 > 查看源码
ADOMyRecordSet.cpp
资源名称：GPRS-GSM040806.rar　[点击查看]
上传用户：yffx2008
上传日期：2014-10-12
资源大小：12414k
文件大小：8k
源码类别：

交通/航空行业

开发平台：

Visual C++

ADOMyRecordSet.cpp：源码内容
  1. // ADOMyRecordSet.cpp: implementation of the CADOMyRecordSet class.
  2. //
  3. //////////////////////////////////////////////////////////////////////
  5. #include "stdafx.h"
  6. #include "GpsSC.h"
  7. #include "ADOMyRecordSet.h"
  9. #ifdef _DEBUG
  10. #undef THIS_FILE
  11. static char THIS_FILE[]=__FILE__;
  12. #define new DEBUG_NEW
  13. #endif
  15. //////////////////////////////////////////////////////////////////////
  16. // Construction/Destruction
  17. //////////////////////////////////////////////////////////////////////
  19. extern CGpsSCApp theApp;
  21. CString CADOMyRecordSet::m_strHabitus="";
  23. CADOMyRecordSet::CADOMyRecordSet()
  24. {
  25. }
  27. CADOMyRecordSet::~CADOMyRecordSet()
  28. {
  29. m_pRecordset->Close();
  30. // m_pRecordset.Release();
  31. m_pRecordset = NULL;
  32. }
  34. void CADOMyRecordSet::Open(CString strTableName,int nType)
  35. {
  36. try
  37. {
  38. m_pRecordset.CreateInstance(__uuidof(Recordset));
  39. CString strSql;
  40. if(nType==0)
  41. strSql = "SELECT * FROM "+strTableName;
  42. else
  43. strSql = "SELECT * FROM "+strTableName+" ORDER BY DriverID";
  44. m_pRecordset->Open(_variant_t(strSql),(IDispatch *)theApp.m_pConnection,adOpenDynamic,adLockOptimistic,adCmdText);
  45. }
  46. catch (_com_error &e)
  47. {
  48. ::MessageBox(NULL,e.Description(),"OPEN提示",
  49. MB_OK | MB_ICONWARNING);
  50. }
  51. }
  53. void CADOMyRecordSet::Open(CString strTableName,CString str_sql)
  54. {
  55. try
  56. {
  57. m_pRecordset.CreateInstance(__uuidof(Recordset));
  58. CString strSql;
  59. if(str_sql!="")
  60. strSql = "SELECT * FROM "+strTableName+" WHERE"+str_sql;
  61. else
  62. strSql = "SELECT * FROM "+strTableName;
  63. m_pRecordset->Open(_variant_t(strSql),(IDispatch *)theApp.m_pConnection,adOpenDynamic,adLockOptimistic,adCmdText);
  64. }
  65. catch (_com_error &e)
  66. {
  67. ::MessageBox(NULL,e.Description(),"OPEN提示",
  68. MB_OK | MB_ICONWARNING);
  69. }
  70. }
  72. void CADOMyRecordSet::Open()
  73. {
  74. CString m_strRoad,RetTime;
  75. CTime time = CTime::GetCurrentTime();
  76. RetTime = time.Format("%Y/%m/%d/");
  78. try
  79. {
  80. m_pRecordset.CreateInstance(__uuidof(Recordset));
  81. CString strSql = "SELECT DISTINCT VehicleID FROM VehicleConveyInfo WHERE DateTime LIKE '"+RetTime+"%' ORDER BY VehicleID";
  82. m_pRecordset->Open(_variant_t(strSql),(IDispatch *)theApp.m_pConnection,adOpenDynamic,adLockOptimistic,adCmdText);
  83. }
  84. catch (_com_error &e)
  85. {
  86. ::MessageBox(NULL,e.Description(),"OPEN提示",
  87. MB_OK | MB_ICONWARNING);
  88. }
  89. }
  91. void CADOMyRecordSet::AddVehicleConveyInfo( CReceDataFromBus *pReceBus,CString str_DriverName)
  92. {
  93. CString m_strRoad,RetTime;
  94. CTime time = CTime::GetCurrentTime();
  95. RetTime = time.Format("%Y/%m/%d/");
  96. if(pReceBus->m_sBusLineID.Right(1)=='U')
  97. m_strRoad="上行";
  98. if(pReceBus->m_sBusLineID.Right(1)=='D')
  99. m_strRoad="下行";
  100. if(pReceBus->m_sOrderType=="23")
  101. m_strHabitus="路堵";
  102. if(pReceBus->m_sOrderType=="24")
  103. m_strHabitus="事故";
  104. if(pReceBus->m_sOrderType=="25")
  105. m_strHabitus="故障";
  106. if(pReceBus->m_sOrderType=="26")
  107. m_strHabitus="报警";
  108. if(pReceBus->m_sOrderType=="27")
  109. m_strHabitus="纠纷";
  110. if(pReceBus->m_sOrderType=="30")
  111. m_strHabitus="正常";
  112. if(pReceBus->m_sOrderType=="31")
  113. m_strHabitus="超速";
  114. if(pReceBus->m_sOrderType=="32")
  115. m_strHabitus="进站";
  116. if(pReceBus->m_sOrderType=="33")
  117. m_strHabitus="出站";
  118. try
  119. {
  120. m_pRecordset->AddNew();
  121. m_pRecordset->PutCollect("VehicleType", _variant_t(pReceBus->m_sVehicleType));
  122. m_pRecordset->PutCollect("DriverName", _variant_t(str_DriverName));
  123. m_pRecordset->PutCollect("DriverID", _variant_t(pReceBus->m_sDriverID));
  124. m_pRecordset->PutCollect("VehicleID", _variant_t(pReceBus->m_sVehicleID));
  125. m_pRecordset->PutCollect("BusWay", _variant_t(pReceBus->m_sBusLineID.Left(3)+m_strRoad));
  126. m_pRecordset->PutCollect("DateTime", _variant_t(RetTime+pReceBus->m_sReceTime));
  127. // m_pRecordset->PutCollect("RoadName", _variant_t(pReceBus->m_sBusRoadSn));
  128. m_pRecordset->PutCollect("RoadID", _variant_t(pReceBus->m_sBusRoadSn));
  129. m_pRecordset->PutCollect("Habitus", _variant_t(m_strHabitus));
  130. m_pRecordset->PutCollect("Longitude", _variant_t(pReceBus->gx));
  131. m_pRecordset->PutCollect("Latitude", _variant_t(pReceBus->gy));
  132. m_pRecordset->PutCollect("Speed", _variant_t(pReceBus->m_sSpeed));
  133. m_pRecordset->PutCollect("Angle", _variant_t(pReceBus->m_sCaurse));
  134. m_pRecordset->Update();
  135. }
  136. catch (_com_error &e)
  137. {
  138. m_pRecordset->Close();
  139. m_pRecordset.Release();
  140. m_pRecordset = NULL;
  141. ::MessageBox(NULL,e.Description(),"VEHICLE添加提示",
  142. MB_OK | MB_ICONWARNING);
  143. }
  144. }
  146. void CADOMyRecordSet::AddClientInfo( CString m_ClientName,
  147. CString str_ClientAge,
  148. CString str_ClientUnits,
  149. CString str_ClientDuty,
  150. CString str_ClientIDcard,
  151. CString str_ClientDrivelicence,
  152. CString str_ClientPhone,
  153. CString str_ClientPassword,
  154. CString str_CarNumber,
  155. CString str_CarType,
  156. CString str_CarColor,
  157. CString str_CarEngine,
  158. CString str_BatholithNo,
  159. CString str_CarPhone)
  160. {
  161. CString RetTime;
  162. CTime time = CTime::GetCurrentTime();
  163. RetTime = time.Format("%Y/%m/%d/%H:%M:%S");
  164. m_strHabitus+="应答";
  165. try
  166. {
  167. m_pRecordset->AddNew();
  168. // m_pRecordset->PutCollect("VehicleID", _variant_t(pReceBus->m_sVehicleID));
  169. // m_pRecordset->PutCollect("Habitus", _variant_t(m_strHabitus));
  170. // m_pRecordset->PutCollect("DateTime", _variant_t(RetTime));
  171. clientinfoSet.m_ClientName        = m_ClientName;
  172. clientinfoSet.m_ClientAge         = m_ClientAge;
  173. clientinfoSet.m_ClientUnits   = m_ClientUnits;
  174. clientinfoSet.m_ClientDuty   = m_ClientDuty;
  175. clientinfoSet.m_ClientIDcard   = m_ClientIDcard;
  176. clientinfoSet.m_ClientDrivelicence= m_ClientDrivelicence;
  177. clientinfoSet.m_ClientPhone       = m_ClientPhone;
  178. clientinfoSet.m_ClientPassword   = m_ClientPassword;
  179. clientinfoSet.m_CarNumber   = m_CarNumber;
  180. clientinfoSet.m_CarType   = m_CarType;
  181. clientinfoSet.m_CarColor   = m_CarColor;
  182. clientinfoSet.m_CarEngine   = m_CarEngine;
  183. clientinfoSet.m_BatholithNo   = m_BatholithNo;
  184. clientinfoSet.m_CarPhone   = m_CarPhone;
  185. m_pRecordset->Update();
  186. }
  187. catch (_com_error &e)
  188. {
  189. m_pRecordset->Close();
  190. m_pRecordset.Release();
  191. m_pRecordset = NULL;
  192. ::MessageBox(NULL,e.Description(),"CENTER添加提示",
  193. MB_OK | MB_ICONWARNING);
  194. }
  195. }
  197. CString CADOMyRecordSet::GetDriverName( CReceDataFromBus *pReceBus)
  198. {
  199. CString strDriverName;
  200. try
  201. {
  202. m_pRecordset.CreateInstance(__uuidof(Recordset));
  203. _variant_t vDriverName;
  204. CString strSql = "SELECT DriverName FROM DriverInfo WHERE DriverID='"+pReceBus->m_sDriverID+"'";
  205. m_pRecordset->Open(_variant_t(strSql),(IDispatch *)theApp.m_pConnection,adOpenDynamic,adLockOptimistic,adCmdText);
  206. if(m_pRecordset->adoEOF==VARIANT_FALSE)
  207. vDriverName = m_pRecordset->GetCollect("DriverName");
  208. strDriverName = (char*)_bstr_t(vDriverName);
  209. vDriverName.Clear();
  210. m_pRecordset->Close();
  211. // m_pRecordset.Release();
  212. m_pRecordset = NULL;
  213. }
  214. catch (_com_error &e)
  215. {
  216. m_pRecordset->Close();
  217. m_pRecordset.Release();
  218. m_pRecordset = NULL;
  219. ::MessageBox(NULL,e.Description(),"OPEN提示",
  220. MB_OK | MB_ICONWARNING);
  221. }
  223. return strDriverName;
  224. }
  226. void CADOMyRecordSet::DeleteAllInfo(CString strTableName,CString str_sql)
  227. {
  228. try
  229. {
  230. m_pRecordset.CreateInstance(__uuidof(Recordset));
  231. CString strSql;
  232. if(str_sql!="")
  233. strSql = "SELECT * FROM "+strTableName+" WHERE"+str_sql;
  234. else
  235. strSql = "SELECT * FROM "+strTableName;
  236. m_pRecordset->Open(_variant_t(strSql),(IDispatch *)theApp.m_pConnection,adOpenDynamic,adLockOptimistic,adCmdText);
  237. if(m_pRecordset->adoEOF==VARIANT_FALSE)
  238. {
  239. m_pRecordset->MoveFirst();
  240. AfxGetApp()->BeginWaitCursor();
  241. while(m_pRecordset->adoEOF==VARIANT_FALSE)
  242. {
  243. m_pRecordset->Delete(adAffectCurrent);
  244. m_pRecordset->MoveNext();
  245. }
  246. AfxGetApp()->EndWaitCursor();
  247. if(str_sql=="")
  248. AfxMessageBox("清空数据成功!");
  249. else
  250. AfxMessageBox("删除当前数据成功!");
  251. }
  252. else
  253. {
  254. AfxMessageBox("数据已清空!");
  255. }
  256. }
  257. catch (_com_error &e)
  258. {
  259. m_pRecordset->Close();
  260. m_pRecordset.Release();
  261. m_pRecordset = NULL;
  262. ::MessageBox(NULL,e.Description(),"OPEN提示",
  263. MB_OK | MB_ICONWARNING);
  264. }
  265. }