DataManager.h 1.1 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556
  1. #ifndef _DATAMANAGER_H_
  2. #define _DATAMANAGER_H_
  3. #include "Global.h"
  4. class CDataManager
  5. {
  6. public:
  7. CDataManager();
  8. ~CDataManager();
  9. static CDataManager *GetInstance()
  10. {
  11. static CDataManager Instance;
  12. return &Instance;
  13. }
  14. //实时提交
  15. int StartRealTimeSubmitThread();
  16. int EndofRealTimeSubmitThread();
  17. int RealTimeSubmitWork();
  18. static DWORD WINAPI RealTimeSubmitThread(LPVOID lpParam);
  19. DWORD ReadOldLog(std::vector<STAllLog> &vtAllLog); // 配置文件中设置要读取的txt;
  20. //全部提交
  21. int StartSubmitAllThread();
  22. int EndofSubmitAllThread();
  23. int SubmitAllWork();
  24. static DWORD WINAPI SubmitAllDataThread(LPVOID lpParam);
  25. ThreadSection* ReturnSection(){return &s_critSection;}
  26. //写数据
  27. DWORD WriteIntoDatabase(std::vector<STGeneralLogData>* pVData);
  28. BOOL IsThreadRuning(){return m_bThreadRuning;}
  29. BOOL IsSubmitAllThreadRuning();
  30. private:
  31. ThreadSection s_critSection;
  32. //实时提交
  33. HANDLE _hThread; // 线程句柄;
  34. BOOL m_bThreadRuning;
  35. // 全部提交;
  36. HANDLE _hThread1; // 线程句柄1;
  37. HANDLE _hCtrl1; // 线程事件1;
  38. BOOL m_bThreadRuning1;
  39. };
  40. #endif