21ic电子技术开发论坛 › 软件应用 › 平台与系统开发 › 一步一步完善我的设计（1）：第一次迭代之--设计 ...
返回列表 发新帖我要提问本帖赏金: 3.00元(功能说明)

一步一步完善我的设计（1）：第一次迭代之--设计

[复制链接]
3474|19
 楼主| keer_zu 发表于 2016-4-19 13:10 | 显示全部楼层 |阅读模式
AC
本帖最后由 keer_zu 于 2016-4-19 13:12 编辑

app.jpg

最近在完成的一个小项目的重构，这是一部分初稿，采用桥接模式和策略模式。
后续会持续迭代之。

ts.jpg

回复

收藏2 举报

打赏榜单

21ic小能手 打赏了 3.00 元 2016-04-25

相关帖子
 楼主| keer_zu 发表于 2016-4-20 09:03 | 显示全部楼层
yyy71cj 发表于 2016-4-20 09:00
ROSE、ROSE、ROSE，这样是不是忒抽象了？

抽象是必须的。
回复

收藏2 举报

21ic小喇叭 发表于 2016-4-20 09:10 | 显示全部楼层
等着继续更新哦，虽然我看不懂，哈哈
回复

收藏2 举报

 楼主| keer_zu 发表于 2016-4-20 09:16 | 显示全部楼层

设计意图

本帖最后由 keer_zu 于 2016-4-20 09:19 编辑

这部分还没有体现在上面设计中，主要是保存程序运行时的一些数据，等程序重启后恢复到之前状态。
这部分代码是半成品，目前修改的意图是实现对写入内容的具体形式解绑定，也就是做得更通用一些。

复制
  1. ///////////////////////////////////// TransTaskDpManager ///////////////////////////////
    


  2. 


  3. 


  4. 

  5. bool TransTaskDpManager::WriteInfoToFile(DpMessageArryType &dpMsg)
    

  6. {
    

  7.         unsigned short size;
    

  8.         //DpMessageType *msg;
    

  9.         char buf[1024];
    

  10.         int i,ret;
    

  11.         FILE*fp=NULL;
    

  12.         string folder = "dpfile";
    

  13.         LoggerWrapper dsLog= LoggerWrapper::GetInstance();
    

  14.         memset(buf,0,sizeof(buf));
    

  15.         string provFileName = "dpfile/" + m_filePrefix + ".prov";
    

  16.         string filename = "dpfile/" + m_filePrefix + ".data";
    


  17. 

  18.         if(!IsExistedDir(folder)){
    

  19.                 MakeDir(folder);
    

  20.                 return false;
    

  21.         }
    

  22.         
    

  23.         fp=fopen(provFileName.c_str(),"ab+");
    

  24.         if(NULL==fp){
    

  25.                 dsLog.Log(true,LOGGER_INFO,"%s:%s:%d   \n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  26.                 return false;
    

  27.         }
    


  28. 

  29.         size = dpMsg.size();
    


  30. 

  31.         dsLog.Log(true,LOGGER_INFO,"size:%d, %s:%s:%d   \n",size,__FILE__,__PRETTY_FUNCTION__,__LINE__);
    


  32. 

  33.         buf[0] = size/256;
    

  34.         buf[1] = size%256;
    


  35. 

  36.         fwrite(buf, 1, 2, fp);
    


  37. 

  38.         string strMsg;
    

  39.         for(i = 0;i < size;i ++){
    

  40.                 //msg = dpMsg[i];
    

  41.                 strMsg = BuildJsonStr(dpMsg[i]);
    


  42. 

  43.                 //delete(msg);
    

  44.                 dpMsg[i].clear();
    


  45. 

  46.                 dsLog.Log(true,LOGGER_INFO,"strMsg:%s, %s:%s:%d   \n",strMsg.c_str(),__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  47.                 
    

  48.                 buf[0] = strMsg.length()/256;
    

  49.                 buf[1] = strMsg.length()%256;
    

  50.                 fwrite(buf, 1, 2, fp);
    


  51. 

  52.                 fwrite(strMsg.c_str(),1,strMsg.length(),fp);
    

  53.         }
    

  54.         
    

  55.         fclose(fp);
    


  56. 

  57.         string cmd0 = "rm -rf " + filename;
    

  58.         systemcmd(cmd0);
    

  59.         string cmd = "mv " + provFileName + " " + filename;
    

  60.         systemcmd(cmd);
    


  61. 

  62.         return true;
    

  63. }
    


  64. 


  65. 


  66. 


  67. 


  68. 

  69. bool TransTaskDpManager::GetTaskinfoFromDpFile(DpMessageArryType &dpMsgArray)
    

  70. {
    

  71.         int i,j;
    

  72.         char buf[2096];
    

  73.         memset(buf,0,sizeof(buf));
    

  74.         unsigned short msgNum,readLen;
    

  75.         size_t ret;
    

  76.         FILE*fp=NULL;
    

  77.         string folder = "dpfile";
    

  78.         string filename = "dpfile/" + m_filePrefix + ".data";
    

  79.         string provFileName = "dpfile/" + m_filePrefix + ".prov";
    

  80.         LoggerWrapper dsLog= LoggerWrapper::GetInstance();
    

  81.         
    

  82.         if(!IsExistedDir(folder)){
    

  83.                 MakeDir(folder);
    

  84.                 return false;
    

  85.         }
    


  86. 

  87.         fp=fopen(filename.c_str(),"r");
    

  88.         if(NULL==fp){
    

  89.                 dsLog.Log(true,LOGGER_INFO,"%s:%s:%d   \n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  90.                 fp = fopen(provFileName.c_str(),"r");
    

  91.                 if(NULL==fp){
    

  92.                         dsLog.Log(true,LOGGER_INFO,"%s:%s:%d   \n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  93.                         return false;
    

  94.                 }
    

  95.                 string cmd = "mv " + provFileName + "  " + filename;
    

  96.                         
    

  97.                 systemcmd(cmd);
    

  98.         } else {
    

  99.                 string cmd = "rm -rf " + provFileName;
    

  100.                 systemcmd(cmd);
    

  101.         }
    


  102. 

  103.         ret = fread(&msgNum,sizeof(unsigned short),1,fp);        
    

  104.         msgNum = (msgNum%256)*256 + msgNum/256;
    

  105.         dsLog.Log(true,LOGGER_INFO,"%s:%s:%d        msg num: %d\n",__FILE__,__PRETTY_FUNCTION__,__LINE__,msgNum);
    


  106. 

  107.         for(i = 0;i < msgNum;i ++){
    

  108.                 ret = fread(&readLen,sizeof(unsigned short),1,fp);
    

  109.                 readLen = (readLen%256)*256 + readLen/256;
    

  110.                 ret = fread(buf,1,readLen,fp);
    


  111. 


  112. 

  113.                 string msg = buf;
    

  114.                 DpMessageType dpMsg;// = new DpMessageType;        
    

  115.                 dsLog.Log(true,LOGGER_INFO,"%s:%s:%d        msg : %s\n",__FILE__,__PRETTY_FUNCTION__,__LINE__,msg.c_str());
    

  116.                 if(GetJsonMap(msg,dpMsg)){
    

  117.                         dpMsgArray.push_back(dpMsg);
    

  118.                 } else {
    

  119.                         fclose(fp);
    

  120.                         return false;
    

  121.                 }
    


  122. 

  123.                 memset(buf,0,sizeof(buf));
    

  124.         }
    


  125. 

  126.         
    


  127. 

  128.         fclose(fp);
    

  129.         return true;
    

  130.         
    

  131. }
    


  132. 


  133. 

  134. bool TransTaskDpManager::CreateDpFile()
    

  135. {
    

  136.         LoggerWrapper dsLog= LoggerWrapper::GetInstance();
    

  137.         DpMessageArryType  dpMsgArry;
    

  138.         
    

  139.         return GetInfoAndWriteToFile(dpMsgArry);
    

  140. }
    


  141. 


  142. 

  143. bool TransTaskDpManager::CreateDpFile(const DpMessageType &dpMsg)
    

  144. {
    

  145.         DpMessageArryType  dpMsgArry;
    

  146.         //DpMessageType msg = dpMsg;
    


  147. 

  148.         dpMsgArry.push_back(dpMsg);
    


  149. 

  150.         return GetInfoAndWriteToFile(dpMsgArry);
    

  151. }
    


  152. 

  153. bool TransTaskDpManager::GetInfoAndWriteToFile(DpMessageArryType &dpMsgArry)
    

  154. {
    

  155.         LoggerWrapper dsLog= LoggerWrapper::GetInstance();
    


  156. 

  157.         if(!GetInfoFromSystem(dpMsgArry)){
    

  158.                 dsLog.Log(true,LOGGER_ERROR,"%s:%s:%d   GetInfoFromSystem error.\n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  159.                 return false;
    

  160.         }
    

  161.         
    

  162.         if(!WriteInfoToFile(dpMsgArry)){
    

  163.                 dsLog.Log(true,LOGGER_ERROR,"%s:%s:%d   WriteInfoToFile error.\n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  164.                 return false;
    

  165.         }
    


  166. 


  167. 

  168.         return true;
    

  169. }
    


  170. 


  171. 

  172. /////////////////////////////////////  DocDpManager /////////////////////////
    

  173. /*
    

  174. bool DocDpManager::GetInfoAndWriteToFile(DpMessageArryType &dpMsgArry)
    

  175. {
    

  176.         LoggerWrapper dsLog= LoggerWrapper::GetInstance();
    


  177. 

  178.         if(!m_queueUser->GetDocWaitQueueMessage(dpMsgArry)){
    

  179.                 dsLog.Log(true,LOGGER_ERROR,"%s:%s:%d   GetDocWaitQueueMessage error.\n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  180.                 return false;
    

  181.         }
    

  182.         
    

  183.         if(!m_queueUser->GetDocRunQueueMessage(dpMsgArry)){
    

  184.                 dsLog.Log(true,LOGGER_ERROR,"%s:%s:%d   GetDocRunQueueMessage error.\n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  185.                 return false;
    

  186.         }
    

  187.         
    

  188.         if(!WriteInfoToFile(dpMsgArry)){
    

  189.                 dsLog.Log(true,LOGGER_ERROR,"%s:%s:%d   WriteInfoToFile error.\n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  190.                 return false;
    

  191.         }
    

  192.         
    

  193.         return true;
    

  194. }
    

  195. */
    


  196. 

  197. bool DocDpManager::GetInfoFromSystem(DpMessageArryType &dpMsgArry)
    

  198. {
    


  199. 

  200. }
    


  201. 

  202. /////////////////////////////////////  DpptDpManager /////////////////////////
    

  203. /*
    

  204. bool DpptDpManager::GetInfoAndWriteToFile(DpMessageArryType &dpMsgArry)
    

  205. {
    

  206.         LoggerWrapper dsLog= LoggerWrapper::GetInstance();
    


  207. 

  208.         if(!m_queueUser->GetDpptWaitQueueMessage(dpMsgArry)){
    

  209.                 dsLog.Log(true,LOGGER_ERROR,"%s:%s:%d   GetDpptWaitQueueMessage error.\n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  210.                 return false;
    

  211.         }
    

  212.         
    

  213.         if(!m_queueUser->GetDpptRunQueueMessage(dpMsgArry)){
    

  214.                 dsLog.Log(true,LOGGER_ERROR,"%s:%s:%d   GetDpptRunQueueMessage error.\n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  215.                 return false;
    

  216.         }
    

  217.         
    

  218.         if(!WriteInfoToFile(dpMsgArry)){
    

  219.                 dsLog.Log(true,LOGGER_ERROR,"%s:%s:%d   dppt WriteInfoToFile error.\n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  220.                 return false;
    

  221.         }
    

  222.         
    

  223.         return true;
    

  224. }
    

  225. */
    


  226. 

  227. bool DpptDpManager::GetInfoFromSystem(DpMessageArryType &dpMsgArry)
    

  228. {
    


  229. 

  230. }
    


  231. 


  232. 


  233. 


  234. 

  235. /////////////////////////////////////  VideoDpManager /////////////////////////
    

  236. /*bool VideoDpManager::GetInfoAndWriteToFile(DpMessageArryType &dpMsgArry)
    

  237. {
    

  238.         LoggerWrapper dsLog= LoggerWrapper::GetInstance();
    


  239. 

  240.         if(!m_queueUser->GetVideoWaitQueueMessage(dpMsgArry)){
    

  241.                 dsLog.Log(true,LOGGER_ERROR,"%s:%s:%d   GetVideoWaitQueueMessage error.\n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  242.                 return false;
    

  243.         }
    

  244.         
    

  245.         if(!m_queueUser->GetVideoRunQueueMessage(dpMsgArry)){
    

  246.                 dsLog.Log(true,LOGGER_ERROR,"%s:%s:%d   GetVideoRunQueueMessage error.\n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  247.                 return false;
    

  248.         }
    

  249.         
    

  250.         if(!WriteInfoToFile(dpMsgArry)){
    

  251.                 dsLog.Log(true,LOGGER_ERROR,"%s:%s:%d   video WriteInfoToFile error.\n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  252.                 return false;
    

  253.         }
    

  254.         
    

  255.         return true;
    

  256. }
    

  257. */
    


  258. 

  259. bool VideoDpManager::GetInfoFromSystem(DpMessageArryType &dpMsgArry)
    

  260. {
    


  261. 

  262. }

回复

收藏2 举报

 楼主| keer_zu 发表于 2016-4-20 09:22 | 显示全部楼层
keer_zu 发表于 2016-4-20 09:16
这部分还没有体现在上面设计中，主要是保存程序运行时的一些数据，等程序重启后恢复到之前状态。
这部分代 ...

从上面我的代码的修改痕迹来看，我是要把数据写入的内容放到子类里面，用多态来支持多种数据内容。同时支持数据内容的增加。
回复

收藏2 举报

 楼主| keer_zu 发表于 2016-4-20 09:25 | 显示全部楼层
哦，对了，上面几个类的定义如下：

复制
  1. class TransTaskDpManager{
    


  2. 

  3. public:        
    

  4.         virtual bool GetTaskinfoFromDpFile(DpMessageArryType &dpMsg);
    

  5.         
    

  6.         bool GetInfoAndWriteToFile(DpMessageArryType &dpMsgArry);
    


  7. 

  8.         virtual bool GetInfoFromSystem(DpMessageArryType &dpMsgArry) = 0;
    

  9.         
    

  10.         bool CreateDpFile();
    

  11.         
    

  12.         bool CreateDpFile(const DpMessageType &dpMsg);
    

  13.         
    

  14. protected:
    

  15.         
    

  16.         bool WriteInfoToFile(DpMessageArryType &dpMsg);
    

  17.         
    

  18.         IQueueUser *m_queueUser;
    

  19.         TaskType m_taskType;
    


  20. 

  21.         string m_filePrefix;
    

  22.         string m_fileContent;
    

  23. };
    


  24. 

  25. class DocDpManager : public TransTaskDpManager{
    

  26. public:
    

  27.         DocDpManager(IQueueUser *usr)
    

  28.         {
    

  29.                 m_taskType = DocTask;
    

  30.                 m_filePrefix = "DOC";
    

  31.                 m_queueUser = usr;
    

  32.         }
    

  33.         
    

  34. //        virtual bool GetInfoAndWriteToFile(DpMessageArryType &dpMsgArry);
    

  35.         virtual bool GetInfoFromSystem(DpMessageArryType &dpMsgArry);
    

  36. };
    


  37. 

  38. class DpptDpManager : public TransTaskDpManager{
    

  39. public:
    

  40.         DpptDpManager(IQueueUser *usr)
    

  41.         {
    

  42.                 m_taskType = DpptTask;
    

  43.                 m_filePrefix = "DPPT";
    

  44.                 m_queueUser = usr;
    

  45.         }
    

  46.         
    

  47. //        virtual bool GetInfoAndWriteToFile(DpMessageArryType &dpMsgArry);
    

  48.         virtual bool GetInfoFromSystem(DpMessageArryType &dpMsgArry);
    

  49. };
    


  50. 

  51. class VideoDpManager : public TransTaskDpManager{
    

  52. public:
    

  53.         VideoDpManager(IQueueUser *usr)        
    

  54.         {
    

  55.                 m_taskType = VideoTask;
    

  56.                 m_filePrefix = "VIDEO";
    

  57.                 m_queueUser = usr;
    

  58.         }
    


  59. 

  60. //        virtual bool GetInfoAndWriteToFile(DpMessageArryType &dpMsgArry);
    

  61.         virtual bool GetInfoFromSystem(DpMessageArryType &dpMsgArry);
    

  62. };
    


  63.
回复

收藏2 举报

eyesee2008 发表于 2016-4-20 11:25 | 显示全部楼层
赞
回复

收藏2 举报

洛理小子 发表于 2016-4-20 12:39 | 显示全部楼层
来学习~~~
回复

收藏2 举报

皈依 发表于 2016-4-20 20:44 | 显示全部楼层
好厉害的样子~
回复

收藏2 举报

 楼主| keer_zu 发表于 2016-4-20 21:15 | 显示全部楼层
经过一天，这部分现在改成这样了,类的定义：

复制
  1. class TransTaskDpManager{
    


  2. 

  3. public:        
    

  4.         bool GetTaskinfoFromDpFile(DpMessageArryType &dpMsg);
    

  5.         bool GetTaskinfoFromDpFile(DpMessageArryType &dpMsg,QueueType qt);
    

  6.         
    

  7.         bool GetInfoAndWriteToFile(DpMessageArryType &dpMsgArry);
    

  8.         bool GetInfoAndWriteToFile(DpMessageArryType &dpMsgArry,QueueType qt);
    


  9. 

  10.         //virtual bool GetInfoFromSystem(DpMessageArryType &dpMsgArry) = 0;
    

  11.         
    

  12.         
    

  13.         bool CreateDpFile();
    

  14.         bool CreateDpFile(QueueType qt);
    

  15.         
    

  16.         bool CreateDpFile(const DpMessageType &dpMsg);
    

  17.         
    

  18. protected:
    

  19.         
    

  20.         bool WriteInfoToFile(DpMessageArryType &dpMsg);
    

  21.         
    

  22.         IQueueUser *m_queueUser;
    

  23.         TaskType m_taskType;
    


  24. 

  25.         string m_filePrefix;
    

  26.         string m_queueType;
    

  27.         string m_fileContent;
    

  28. };
    


  29. 

  30. class DocDpManager : public TransTaskDpManager{
    

  31. public:
    

  32.         DocDpManager(IQueueUser *usr)
    

  33.         {
    

  34.                 m_taskType = DocTask;
    

  35.                 m_filePrefix = "DOC";
    

  36.                 m_queueType = "";
    

  37.                 m_queueUser = usr;
    

  38.         }
    

  39.         
    

  40.         //virtual bool GetInfoFromSystem(DpMessageArryType &dpMsgArry);
    


  41. 

  42. };
    


  43. 

  44. class DpptDpManager : public TransTaskDpManager{
    

  45. public:
    

  46.         DpptDpManager(IQueueUser *usr)
    

  47.         {
    

  48.                 m_taskType = DpptTask;
    

  49.                 m_filePrefix = "DPPT";
    

  50.                 m_queueType = "";
    

  51.                 m_queueUser = usr;
    

  52.         }
    

  53.         
    


  54. 

  55.         //virtual bool GetInfoFromSystem(DpMessageArryType &dpMsgArry);
    


  56. 

  57. };
    


  58. 

  59. class VideoDpManager : public TransTaskDpManager{
    

  60. public:
    

  61.         VideoDpManager(IQueueUser *usr)        
    

  62.         {
    

  63.                 m_taskType = VideoTask;
    

  64.                 m_filePrefix = "VIDEO";
    

  65.                 m_queueType = "";
    

  66.                 m_queueUser = usr;
    

  67.         }
    


  68. 

  69.         //virtual bool GetInfoFromSystem(DpMessageArryType &dpMsgArry);
    

  70. };
    


  71. 


  72. 

  73. class DataPresistence:public IDataPresistence{
    

  74. protected:
    

  75.         IQueueUser *m_queueUser;
    

  76.         TransTaskDpManager *m_taskDpManager;
    

  77. public:
    

  78.         
    

  79.         DataPresistence(IQueueUser *queueUser);
    

  80.         static DataPresistence& GetInstance(IQueueUser *queueUser);
    


  81. 

  82.         
    

  83.         //virtual IDataPresistence &CreatePresistence(IQueueUser *user);
    

  84.         virtual bool DpGetMessage(DpMessageArryType &dpMsg,TaskType taskType);
    

  85.         virtual bool DpGetWaitMessage(DpMessageArryType &dpMsg,TaskType taskType);
    

  86.         virtual bool DpGetRunMessage(DpMessageArryType &dpMsg,TaskType taskType);
    

  87.         virtual bool CreateDpMsgFile(TaskType taskType);
    

  88.         virtual bool CreateDpMsgFile(const DpMessageType &dpMsg,TaskType taskType);
    

  89.         virtual bool CreateWaitMsgFile(TaskType taskType);
    

  90.         virtual bool CreateRunMsgFile(TaskType taskType);
    

  91.         
    

  92. };
    


  93.
回复

收藏2 举报

 楼主| keer_zu 发表于 2016-4-20 21:16 | 显示全部楼层
函数实现部分：

复制
  1. DataPresistence& DataPresistence::GetInstance(IQueueUser *queueUser)
    

  2. {
    

  3.         static  DataPresistence instance_(queueUser);
    

  4.         return instance_; 
    


  5. 

  6. }
    


  7. 

  8. DataPresistence::DataPresistence(IQueueUser *queueUser)
    

  9.         :m_queueUser(queueUser)
    

  10. {
    

  11.         
    

  12. }
    


  13. 

  14. //IDataPresistence &DataPresistence::CreatePresistence(IQueueUser *user)
    

  15. //{
    

  16. //        return GetInstance(user);
    

  17. //}
    


  18. 


  19. 

  20. bool DataPresistence::DpGetMessage(DpMessageArryType &dpMsg,TaskType taskType)
    

  21. {
    

  22.         set_task_dp_manager(taskType);
    

  23.         m_taskDpManager->GetTaskinfoFromDpFile(dpMsg);
    

  24.         
    

  25.         return true;
    

  26. }
    


  27. 

  28. bool DataPresistence::DpGetWaitMessage(DpMessageArryType &dpMsg,TaskType taskType)
    

  29. {
    

  30.         
    

  31.         return true;
    

  32. }
    


  33. 


  34. 

  35. bool DataPresistence::DpGetRunMessage(DpMessageArryType &dpMsg,TaskType taskType)
    

  36. {
    


  37. 

  38.         return true;
    

  39. }
    


  40. 


  41. 

  42. bool DataPresistence::CreateDpMsgFile(TaskType taskType)
    

  43. {
    

  44.         set_task_dp_manager(taskType);
    

  45.         m_taskDpManager->CreateDpFile();
    

  46.         return true;
    

  47. }
    


  48. 

  49. bool DataPresistence::CreateDpMsgFile(const DpMessageType &dpMsg,TaskType taskType)
    

  50. {
    

  51.         set_task_dp_manager(taskType);
    

  52.         m_taskDpManager->CreateDpFile(dpMsg);
    

  53.         
    

  54.         return true;
    

  55. }
    


  56. 

  57. bool DataPresistence::CreateWaitMsgFile(TaskType taskType)
    

  58. {
    

  59.         set_task_dp_manager(taskType);
    

  60.         m_taskDpManager->CreateDpFile(QueueWait);
    

  61. }
    


  62. 

  63. bool DataPresistence::CreateRunMsgFile(TaskType taskType)
    

  64. {
    

  65.         set_task_dp_manager(taskType);
    

  66.         m_taskDpManager->CreateDpFile(QueueRuning);
    

  67. }
    


  68. 


  69. 

  70. ///////////////////////////////////// TransTaskDpManager ///////////////////////////////
    


  71. 


  72. 


  73. 

  74. bool TransTaskDpManager::WriteInfoToFile(DpMessageArryType &dpMsg)
    

  75. {
    

  76.         unsigned short size;
    

  77.         //DpMessageType *msg;
    

  78.         char buf[1024];
    

  79.         int i,ret;
    

  80.         FILE*fp=NULL;
    

  81.         string folder = "dpfile";
    

  82.         LoggerWrapper dsLog= LoggerWrapper::GetInstance();
    

  83.         memset(buf,0,sizeof(buf));
    

  84.         string provFileName = "dpfile/" + m_filePrefix + m_queueType + ".prov";
    

  85.         string filename = "dpfile/" + m_filePrefix + m_queueType + ".data";
    


  86. 

  87.         if(!IsExistedDir(folder)){
    

  88.                 MakeDir(folder);
    

  89.                 return false;
    

  90.         }
    

  91.         
    

  92.         fp=fopen(provFileName.c_str(),"ab+");
    

  93.         if(NULL==fp){
    

  94.                 dsLog.Log(true,LOGGER_INFO,"%s:%s:%d   \n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  95.                 return false;
    

  96.         }
    


  97. 

  98.         size = dpMsg.size();
    


  99. 

  100.         dsLog.Log(true,LOGGER_INFO,"size:%d, %s:%s:%d   \n",size,__FILE__,__PRETTY_FUNCTION__,__LINE__);
    


  101. 

  102.         buf[0] = size/256;
    

  103.         buf[1] = size%256;
    


  104. 

  105.         fwrite(buf, 1, 2, fp);
    


  106. 

  107.         string strMsg;
    

  108.         for(i = 0;i < size;i ++){
    

  109.                 //msg = dpMsg[i];
    

  110.                 strMsg = BuildJsonStr(dpMsg[i]);
    


  111. 

  112.                 //delete(msg);
    

  113.                 dpMsg[i].clear();
    


  114. 

  115.                 dsLog.Log(true,LOGGER_INFO,"strMsg:%s, %s:%s:%d   \n",strMsg.c_str(),__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  116.                 
    

  117.                 buf[0] = strMsg.length()/256;
    

  118.                 buf[1] = strMsg.length()%256;
    

  119.                 fwrite(buf, 1, 2, fp);
    


  120. 

  121.                 fwrite(strMsg.c_str(),1,strMsg.length(),fp);
    

  122.         }
    

  123.         
    

  124.         fclose(fp);
    


  125. 

  126.         string cmd0 = "rm -rf " + filename;
    

  127.         systemcmd(cmd0);
    

  128.         string cmd = "mv " + provFileName + " " + filename;
    

  129.         systemcmd(cmd);
    


  130. 

  131.         return true;
    

  132. }
    


  133. 


  134. 

  135. bool TransTaskDpManager::GetTaskinfoFromDpFile(DpMessageArryType &dpMsgArray,QueueType qt)
    

  136. {
    

  137.         switch(qt){
    

  138.                 case QueueWait:
    

  139.                         m_queueType = "_WAIT";
    

  140.                         break;
    

  141.                 case QueueRuning:
    

  142.                         m_queueType = "_RUN";
    

  143.                         break;
    

  144.                 default:
    

  145.                         return false;
    

  146.         }
    

  147.         return GetTaskinfoFromDpFile(dpMsgArray);
    

  148. }
    


  149. 


  150. 

  151. bool TransTaskDpManager::GetTaskinfoFromDpFile(DpMessageArryType &dpMsgArray)
    

  152. {
    

  153.         int i,j;
    

  154.         char buf[2096];
    

  155.         memset(buf,0,sizeof(buf));
    

  156.         unsigned short msgNum,readLen;
    

  157.         size_t ret;
    

  158.         FILE*fp=NULL;
    

  159.         string folder = "dpfile";
    

  160.         string filename = "dpfile/" + m_filePrefix + m_queueType + ".data";
    

  161.         string provFileName = "dpfile/" + m_filePrefix + m_queueType + ".prov";
    

  162.         LoggerWrapper dsLog= LoggerWrapper::GetInstance();
    

  163.         
    

  164.         if(!IsExistedDir(folder)){
    

  165.                 MakeDir(folder);
    

  166.                 return false;
    

  167.         }
    


  168. 

  169.         fp=fopen(filename.c_str(),"r");
    

  170.         if(NULL==fp){
    

  171.                 dsLog.Log(true,LOGGER_INFO,"%s:%s:%d   \n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  172.                 fp = fopen(provFileName.c_str(),"r");
    

  173.                 if(NULL==fp){
    

  174.                         dsLog.Log(true,LOGGER_INFO,"%s:%s:%d   \n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  175.                         return false;
    

  176.                 }
    

  177.                 string cmd = "mv " + provFileName + "  " + filename;
    

  178.                         
    

  179.                 systemcmd(cmd);
    

  180.         } else {
    

  181.                 string cmd = "rm -rf " + provFileName;
    

  182.                 systemcmd(cmd);
    

  183.         }
    


  184. 

  185.         ret = fread(&msgNum,sizeof(unsigned short),1,fp);        
    

  186.         msgNum = (msgNum%256)*256 + msgNum/256;
    

  187.         dsLog.Log(true,LOGGER_INFO,"%s:%s:%d        msg num: %d\n",__FILE__,__PRETTY_FUNCTION__,__LINE__,msgNum);
    


  188. 

  189.         for(i = 0;i < msgNum;i ++){
    

  190.                 ret = fread(&readLen,sizeof(unsigned short),1,fp);
    

  191.                 readLen = (readLen%256)*256 + readLen/256;
    

  192.                 ret = fread(buf,1,readLen,fp);
    


  193. 


  194. 

  195.                 string msg = buf;
    

  196.                 DpMessageType dpMsg;// = new DpMessageType;        
    

  197.                 dsLog.Log(true,LOGGER_INFO,"%s:%s:%d        msg : %s\n",__FILE__,__PRETTY_FUNCTION__,__LINE__,msg.c_str());
    

  198.                 if(GetJsonMap(msg,dpMsg)){
    

  199.                         dpMsgArray.push_back(dpMsg);
    

  200.                 } else {
    

  201.                         fclose(fp);
    

  202.                         return false;
    

  203.                 }
    


  204. 

  205.                 memset(buf,0,sizeof(buf));
    

  206.         }
    


  207. 

  208.         
    


  209. 

  210.         fclose(fp);
    

  211.         return true;
    

  212.         
    

  213. }
    


  214. 


  215. 

  216. bool TransTaskDpManager::CreateDpFile()
    

  217. {
    

  218.         LoggerWrapper dsLog= LoggerWrapper::GetInstance();
    

  219.         DpMessageArryType  dpMsgArry;
    

  220.         
    

  221.         return GetInfoAndWriteToFile(dpMsgArry);
    

  222. }
    


  223. 


  224. 

  225. bool TransTaskDpManager::CreateDpFile(QueueType qt)
    

  226. {
    

  227.         LoggerWrapper dsLog= LoggerWrapper::GetInstance();
    

  228.         DpMessageArryType  dpMsgArry;
    

  229.         
    

  230.         return GetInfoAndWriteToFile(dpMsgArry,qt);
    

  231. }
    


  232. 


  233. 

  234. bool TransTaskDpManager::CreateDpFile(const DpMessageType &dpMsg)
    

  235. {
    

  236.         DpMessageArryType  dpMsgArry;
    

  237.         //DpMessageType msg = dpMsg;
    


  238. 

  239.         dpMsgArry.push_back(dpMsg);
    


  240. 

  241.         return GetInfoAndWriteToFile(dpMsgArry);
    

  242. }
    


  243. 

  244. bool TransTaskDpManager::GetInfoAndWriteToFile(DpMessageArryType &dpMsgArry)
    

  245. {
    

  246.         LoggerWrapper dsLog= LoggerWrapper::GetInstance();
    


  247. 

  248.         //if(!GetInfoFromSystem(dpMsgArry)){
    

  249.         //        dsLog.Log(true,LOGGER_ERROR,"%s:%s:%d   GetInfoFromSystem error.\n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  250.         //        return false;
    

  251.         //}
    


  252. 

  253.         bool ret = false;
    

  254.         QueueInfo *qi = new QueueInfoAdapter(*m_queueUser);
    


  255. 

  256.         //InfoComponent* pCom = new ConcreteInfoComponent(dpMsgArry);   
    

  257.         ConcreteInfoComponent com(dpMsgArry);
    

  258.         InfoAdder* pDec = NULL;
    

  259.         pDec = new RunQueueInfoAdder(&com,*qi,m_taskType);          
    

  260.         pDec = new WaitQueueInfoAdder(pDec,*qi,m_taskType);         
    

  261.         ret = pDec->Operation();
    


  262. 

  263.         delete qi;
    

  264.         delete pDec;
    


  265. 

  266.         if(ret == false){
    

  267.                 dsLog.Log(true,LOGGER_ERROR,"%s:%s:%d   GetQueueInfo error.\n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  268.                 return false;
    

  269.         }
    

  270.         
    

  271.         if(!WriteInfoToFile(dpMsgArry)){
    

  272.                 dsLog.Log(true,LOGGER_ERROR,"%s:%s:%d   WriteInfoToFile error.\n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  273.                 return false;
    

  274.         }
    


  275. 


  276. 

  277.         return true;
    

  278. }
    


  279. 


  280. 

  281. bool TransTaskDpManager::GetInfoAndWriteToFile(DpMessageArryType &dpMsgArry,QueueType qt)
    

  282. {
    

  283.         LoggerWrapper dsLog= LoggerWrapper::GetInstance();
    


  284. 

  285.         //if(!GetInfoFromSystem(dpMsgArry,qt)){
    

  286.         //        dsLog.Log(true,LOGGER_ERROR,"%s:%s:%d   GetInfoFromSystem error.\n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  287.         //        return false;
    

  288.         //}
    

  289.         QueueInfo *qi = new QueueInfoAdapter(*m_queueUser);
    

  290.         bool ret = false;
    

  291.         //InfoComponent* pCom = new ConcreteInfoComponent(dpMsgArry);   
    

  292.         ConcreteInfoComponent com(dpMsgArry);
    

  293.         InfoAdder* pDec = NULL;
    

  294.         switch(qt){
    

  295.                 case QueueWait:
    

  296.                         m_queueType = "_WAIT";
    

  297.                         pDec = new WaitQueueInfoAdder(&com,*qi,m_taskType);   
    

  298.                         break;
    

  299.                 case QueueRuning:
    

  300.                         m_queueType = "_RUN";
    

  301.                         pDec = new RunQueueInfoAdder(&com,*qi,m_taskType);
    

  302.                         break;
    

  303.                 default:
    

  304.                         ret = false;
    

  305.         }
    

  306.         
    

  307.         ret = pDec->Operation();
    


  308. 

  309.         delete qi;
    

  310.         delete pDec;
    

  311.         if(ret == false){
    

  312.                 dsLog.Log(true,LOGGER_ERROR,"%s:%s:%d   GetQueueInfo error.\n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  313.                 return false;
    

  314.         }
    

  315.         
    

  316.         if(!WriteInfoToFile(dpMsgArry)){
    

  317.                 dsLog.Log(true,LOGGER_ERROR,"%s:%s:%d   WriteInfoToFile error.\n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  318.                 return false;
    

  319.         }
    


  320. 


  321. 

  322.         return true;
    

  323. }
    


  324. 


  325. 

  326. /////////////////////////////////////  DocDpManager /////////////////////////
    

  327. /*
    

  328. bool DocDpManager::GetInfoAndWriteToFile(DpMessageArryType &dpMsgArry)
    

  329. {
    

  330.         LoggerWrapper dsLog= LoggerWrapper::GetInstance();
    


  331. 

  332.         if(!m_queueUser->GetDocWaitQueueMessage(dpMsgArry)){
    

  333.                 dsLog.Log(true,LOGGER_ERROR,"%s:%s:%d   GetDocWaitQueueMessage error.\n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  334.                 return false;
    

  335.         }
    

  336.         
    

  337.         if(!m_queueUser->GetDocRunQueueMessage(dpMsgArry)){
    

  338.                 dsLog.Log(true,LOGGER_ERROR,"%s:%s:%d   GetDocRunQueueMessage error.\n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  339.                 return false;
    

  340.         }
    

  341.         
    

  342.         if(!WriteInfoToFile(dpMsgArry)){
    

  343.                 dsLog.Log(true,LOGGER_ERROR,"%s:%s:%d   WriteInfoToFile error.\n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  344.                 return false;
    

  345.         }
    

  346.         
    

  347.         return true;
    

  348. }
    


  349. 


  350. 

  351. bool DocDpManager::GetInfoFromSystem(DpMessageArryType &dpMsgArry)
    

  352. {
    

  353.         QueueInfo *qi = new QueueInfoAdapter(*m_queueUser);
    


  354. 

  355.         InfoComponent* pCom = new ConcreteInfoComponent(dpMsgArry);   
    

  356.         ConcreteInfoComponent com(dpMsgArry);
    

  357.         InfoAdder* pDec = NULL;
    

  358.         pDec = new RunQueueInfoAdder(pCom,*qi,DocTask);          
    

  359.         pDec = new WaitQueueInfoAdder(pDec,*qi,DocTask);         
    

  360.         pDec->Operation();
    


  361. 

  362.         delete qi;
    

  363.         delete pDec;
    

  364. }
    


  365. 


  366. 


  367. 

  368. /////////////////////////////////////  DpptDpManager /////////////////////////
    


  369. 

  370. bool DpptDpManager::GetInfoAndWriteToFile(DpMessageArryType &dpMsgArry)
    

  371. {
    

  372.         LoggerWrapper dsLog= LoggerWrapper::GetInstance();
    


  373. 

  374.         if(!m_queueUser->GetDpptWaitQueueMessage(dpMsgArry)){
    

  375.                 dsLog.Log(true,LOGGER_ERROR,"%s:%s:%d   GetDpptWaitQueueMessage error.\n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  376.                 return false;
    

  377.         }
    

  378.         
    

  379.         if(!m_queueUser->GetDpptRunQueueMessage(dpMsgArry)){
    

  380.                 dsLog.Log(true,LOGGER_ERROR,"%s:%s:%d   GetDpptRunQueueMessage error.\n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  381.                 return false;
    

  382.         }
    

  383.         
    

  384.         if(!WriteInfoToFile(dpMsgArry)){
    

  385.                 dsLog.Log(true,LOGGER_ERROR,"%s:%s:%d   dppt WriteInfoToFile error.\n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  386.                 return false;
    

  387.         }
    

  388.         
    

  389.         return true;
    

  390. }
    


  391. 


  392. 

  393. bool DpptDpManager::GetInfoFromSystem(DpMessageArryType &dpMsgArry)
    

  394. {
    

  395.         QueueInfo *qi = new QueueInfoAdapter(*m_queueUser);
    


  396. 

  397.         InfoComponent* pCom = new ConcreteInfoComponent(dpMsgArry);   
    

  398.         ConcreteInfoComponent com(dpMsgArry);
    

  399.         InfoAdder* pDec = NULL;
    

  400.         pDec = new RunQueueInfoAdder(pCom,*qi,DpptTask);          
    

  401.         pDec = new WaitQueueInfoAdder(pDec,*qi,DpptTask);         
    

  402.         pDec->Operation();
    


  403. 

  404.         delete qi;
    

  405.         delete pDec;
    

  406. }
    


  407. 


  408. 


  409. 

  410. /////////////////////////////////////  VideoDpManager /////////////////////////
    

  411. bool VideoDpManager::GetInfoAndWriteToFile(DpMessageArryType &dpMsgArry)
    

  412. {
    

  413.         LoggerWrapper dsLog= LoggerWrapper::GetInstance();
    


  414. 

  415.         if(!m_queueUser->GetVideoWaitQueueMessage(dpMsgArry)){
    

  416.                 dsLog.Log(true,LOGGER_ERROR,"%s:%s:%d   GetVideoWaitQueueMessage error.\n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  417.                 return false;
    

  418.         }
    

  419.         
    

  420.         if(!m_queueUser->GetVideoRunQueueMessage(dpMsgArry)){
    

  421.                 dsLog.Log(true,LOGGER_ERROR,"%s:%s:%d   GetVideoRunQueueMessage error.\n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  422.                 return false;
    

  423.         }
    

  424.         
    

  425.         if(!WriteInfoToFile(dpMsgArry)){
    

  426.                 dsLog.Log(true,LOGGER_ERROR,"%s:%s:%d   video WriteInfoToFile error.\n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  427.                 return false;
    

  428.         }
    

  429.         
    

  430.         return true;
    

  431. }
    


  432. 

  433. bool VideoDpManager::GetInfoFromSystem(DpMessageArryType &dpMsgArry)
    

  434. {
    

  435.         bool ret = false;
    

  436.         QueueInfo *qi = new QueueInfoAdapter(*m_queueUser);
    


  437. 

  438.         InfoComponent* pCom = new ConcreteInfoComponent(dpMsgArry);   
    

  439.         ConcreteInfoComponent com(dpMsgArry);
    

  440.         InfoAdder* pDec = NULL;
    

  441.         pDec = new RunQueueInfoAdder(pCom,*qi,VideoTask);          
    

  442.         pDec = new WaitQueueInfoAdder(pDec,*qi,VideoTask);         
    

  443.         ret = pDec->Operation();
    


  444. 

  445.         delete qi;
    

  446.         delete pDec;
    


  447. 

  448.         return ret;
    

  449. }
    

  450. */
    


  451. 


  452. 


  453. 


  454.
回复

收藏2 举报

 楼主| keer_zu 发表于 2016-4-20 21:22 | 显示全部楼层
你会发现，原来在TransTaskDpManager的子类中多态实现的接口：GetInfoFromSystem，都被我用/* */注释掉了。
为什么呢？因为我将要获取（并写入文件）的信息都通过单独的类去实现了，增加的类通过装饰者模式可以动态添加这些要写入的信息。
具体做法如下面代码：

类的定义：
复制
  1. #include "IDataPersistence.h"
    


  2. 

  3. class QueueInfo
    

  4. {
    

  5. public:
    

  6.         QueueInfo();
    

  7.         virtual ~QueueInfo();
    

  8.         virtual bool GetWaitQueueMessage(DpMessageArryType &dpMsgArry,TaskType taskType);
    

  9.         virtual bool GetRunQueueMessage(DpMessageArryType &dpMsgArry,TaskType taskType);
    

  10. };
    


  11. 


  12. 

  13. class QueueInfoAdapter : public QueueInfo
    

  14. {
    

  15. public:
    

  16.         QueueInfoAdapter(IQueueUser &);
    

  17.         ~QueueInfoAdapter();
    

  18.         virtual bool GetWaitQueueMessage(DpMessageArryType &dpMsgArry,TaskType taskType);
    

  19.         virtual bool GetRunQueueMessage(DpMessageArryType &dpMsgArry,TaskType taskType);
    

  20. private:
    

  21.          IQueueUser *m_queueUser;
    

  22. };
    


  23. 


  24. 

  25. //InfoComponent抽象类，定义该类对象的接口
    

  26. class InfoComponent
    

  27. {
    

  28. public:
    

  29.         virtual ~InfoComponent();
    

  30.         virtual bool Operation()=0;
    

  31. protected:
    

  32.         DpMessageArryType *m_msgArry;
    

  33.         InfoComponent();
    

  34. };
    


  35. 

  36. //ConcreteInfoAdder：具体的InfoComponent对象，可以给该对象动态 添加职责
    

  37. class ConcreteInfoComponent:public InfoComponent
    

  38. {
    

  39. public:
    

  40. //        ConcreteInfoComponent();
    

  41.         ConcreteInfoComponent(DpMessageArryType &msgArray);
    

  42.         ~ConcreteInfoComponent();
    

  43.         virtual bool Operation();
    

  44. };
    


  45. 

  46. //InfoAdder：装饰抽象类，继承自InfoComponent
    

  47. class InfoAdder:public InfoComponent
    

  48. {
    

  49. public:
    

  50.         InfoAdder(InfoComponent* com);
    

  51.         void SetInfoComponent(InfoComponent* com);
    

  52.         virtual ~InfoAdder();
    

  53.         virtual bool Operation();
    

  54. protected:
    

  55.         InfoComponent* _com;
    

  56. };
    


  57. 

  58. class RunQueueInfoAdder : public InfoAdder
    

  59. {
    

  60. public:
    

  61.         RunQueueInfoAdder(InfoComponent* com,QueueInfo &,TaskType taskType);
    

  62.         ~RunQueueInfoAdder();
    

  63.         virtual bool Operation();
    

  64.         bool AddBehavor();
    

  65. private:
    

  66.         TaskType m_taskType;
    

  67.         QueueInfo *m_queueInfo;
    

  68. };
    


  69. 


  70. 

  71. class WaitQueueInfoAdder : public InfoAdder
    

  72. {
    

  73. public:
    

  74.         WaitQueueInfoAdder(InfoComponent* com,QueueInfo &,TaskType taskType);
    

  75.         ~WaitQueueInfoAdder();
    

  76.         virtual bool Operation();
    

  77.         bool AddBehavor();
    

  78. private:
    

  79.         TaskType m_taskType;
    

  80.         QueueInfo *m_queueInfo;
    

  81. };


回复

收藏2 举报

 楼主| keer_zu 发表于 2016-4-20 21:25 | 显示全部楼层
其中QueueInfoAdapter通过适配器模式将 原来获取信息的接口转变为 QueueInfo 接口。采用的是对象适配器而不是类适配器。
紧接下来的几个类实现了装饰者模式。

下面代码是这些类的方法定义：
复制

  1. 

  2. ///////////////////////////////// QueueInfo ////////////////////////////////////
    


  3. 

  4. QueueInfo::QueueInfo()
    

  5. {
    


  6. 

  7. }
    


  8. 

  9. QueueInfo::~QueueInfo()
    

  10. {
    


  11. 

  12. }
    


  13. 

  14. bool QueueInfo::GetWaitQueueMessage(DpMessageArryType &dpMsgArry,TaskType taskType)
    

  15. {
    


  16. 

  17. }
    


  18. 

  19. bool QueueInfo::GetRunQueueMessage(DpMessageArryType &dpMsgArry,TaskType taskType)
    

  20. {
    


  21. 

  22. }
    


  23. 


  24. 


  25. 

  26. //////////////////////////////// QueueInfoAdapter //////////////////////////////
    


  27. 


  28. 

  29. QueueInfoAdapter::QueueInfoAdapter(IQueueUser &queueUser)
    

  30. {
    

  31.         m_queueUser = &queueUser;
    

  32. }
    


  33. 

  34. QueueInfoAdapter::~QueueInfoAdapter()
    

  35. {
    


  36. 

  37. }
    


  38. 

  39. bool QueueInfoAdapter::GetWaitQueueMessage(DpMessageArryType &dpMsgArry,TaskType taskType)
    

  40. {
    

  41.         switch(taskType){
    

  42.                 case DocTask:
    

  43.                         return m_queueUser->GetDocWaitQueueMessage(dpMsgArry);
    

  44.                 case VideoTask:
    

  45.                         return m_queueUser->GetVideoWaitQueueMessage(dpMsgArry);
    

  46.                 case DpptTask:
    

  47.                         return m_queueUser->GetDpptWaitQueueMessage(dpMsgArry);
    

  48.                 default:
    

  49.                         return false;
    

  50.         }
    

  51. }
    


  52. 

  53. bool QueueInfoAdapter::GetRunQueueMessage(DpMessageArryType &dpMsgArry,TaskType taskType)
    

  54. {
    

  55.         switch(taskType){
    

  56.                 case DocTask:
    

  57.                         return m_queueUser->GetDocRunQueueMessage(dpMsgArry);
    

  58.                 case VideoTask:
    

  59.                         return m_queueUser->GetVideoRunQueueMessage(dpMsgArry);
    

  60.                 case DpptTask:
    

  61.                         return m_queueUser->GetDpptRunQueueMessage(dpMsgArry);
    

  62.                 default:
    

  63.                         return false;
    

  64.         }
    

  65. }
    


  66. 


  67. 

  68. //////////////////////////////// InfoComponent /////////////////////////////
    

  69. InfoComponent::InfoComponent()
    

  70. {
    


  71. 

  72. }
    


  73. 

  74. InfoComponent::~InfoComponent()
    

  75. {
    

  76.         cout << "~InfoComponent" << endl;
    

  77. }
    


  78. 

  79. //////////////////////////////// ConcreteInfoComponent /////////////////////////////
    

  80. ConcreteInfoComponent::ConcreteInfoComponent(DpMessageArryType &msgArray)
    

  81. {
    

  82.         m_msgArry = &msgArray;
    

  83. }
    


  84. 

  85. ConcreteInfoComponent::~ConcreteInfoComponent()
    

  86. {
    

  87.         cout << "~ConcreteInfoComponent" << endl;
    

  88. }
    


  89. 

  90. bool ConcreteInfoComponent::Operation()
    

  91. {
    

  92.         //cout << "ConcreteInfoComponent::Operation" << endl;
    

  93.         return true;
    

  94. }
    


  95. 


  96. 

  97. //////////////////////////////// InfoAdder /////////////////////////////
    

  98. InfoAdder::InfoAdder(InfoComponent* com)
    

  99. {
    

  100.         this->_com = com;
    

  101. }
    


  102. 

  103. void InfoAdder::SetInfoComponent(InfoComponent* com)
    

  104. {
    

  105.         this->_com = com;
    

  106. }
    


  107. 

  108. InfoAdder::~InfoAdder()
    

  109. {
    

  110.         cout << "~InfoAdder" << endl;
    

  111.         delete this->_com;
    

  112.         this->_com = NULL;
    

  113. }
    


  114. 

  115. bool InfoAdder::Operation()
    

  116. {
    


  117. 

  118. }
    


  119. 

  120. //////////////////////////////// RunQueueInfoAdder /////////////////////////////
    


  121. 

  122. RunQueueInfoAdder::RunQueueInfoAdder(InfoComponent* com,QueueInfo &queueInfo,TaskType taskType):InfoAdder(com)
    

  123. {
    

  124.         m_queueInfo = &queueInfo;
    

  125.         m_taskType = taskType;
    

  126. }
    


  127. 

  128. RunQueueInfoAdder::~RunQueueInfoAdder()
    

  129. {
    

  130.         cout << "~RunQueueInfoAdder" << endl;
    

  131. }
    


  132. 

  133. bool RunQueueInfoAdder::Operation()
    

  134. {
    

  135.         this->_com->Operation();
    

  136.         this->AddBehavor();
    

  137. }
    


  138. 

  139. bool RunQueueInfoAdder::AddBehavor()
    

  140. {
    

  141.         LoggerWrapper dsLog= LoggerWrapper::GetInstance();
    

  142.         
    

  143.         if(!m_queueInfo->GetRunQueueMessage(*m_msgArry,m_taskType)){
    

  144.                 dsLog.Log(true,LOGGER_ERROR,"%s:%s:%d   GetDpptRunQueueMessage error.\n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  145.                 return false;
    

  146.         }
    


  147. 

  148.         return true;
    

  149. }
    


  150. 


  151. 

  152. //////////////////////////////// WaitQueueInfoAdder /////////////////////////////
    


  153. 

  154. WaitQueueInfoAdder::WaitQueueInfoAdder(InfoComponent* com,QueueInfo &queueInfo,TaskType taskType):InfoAdder(com)
    

  155. {
    

  156.         m_queueInfo = &queueInfo;
    

  157.         m_taskType = taskType;
    

  158. }
    


  159. 

  160. WaitQueueInfoAdder::~WaitQueueInfoAdder()
    

  161. {
    

  162.         cout << "~RunQueueInfoAdder" << endl;
    

  163. }
    


  164. 

  165. bool WaitQueueInfoAdder::Operation()
    

  166. {
    

  167.         this->_com->Operation();
    

  168.         this->AddBehavor();
    

  169. }
    


  170. 

  171. bool WaitQueueInfoAdder::AddBehavor()
    

  172. {
    

  173.         LoggerWrapper dsLog= LoggerWrapper::GetInstance();
    


  174. 

  175.         if(!m_queueInfo->GetWaitQueueMessage(*m_msgArry,m_taskType)){
    

  176.                 dsLog.Log(true,LOGGER_ERROR,"%s:%s:%d   GetWaitQueueMessage error.\n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  177.                 return false;
    

  178.         }
    


  179. 

  180.         return true;
    

  181. }



回复

收藏2 举报

 楼主| keer_zu 发表于 2016-4-20 21:28 | 显示全部楼层
以上动态获取信息完成后，如果再有新的信息加入，我只要增加新的InfoAdder就可以了。具体的InfoAdder中关注获取的信息细节，但是InfoAdder本身是不关注这些的。
回复

收藏2 举报

 楼主| keer_zu 发表于 2016-4-21 11:25 | 显示全部楼层
修改了两处：1. 对象中m_msgArry成员没有设置。 2. ConcreteInfoComponent 对象出现重复释放。

然后就可以通过测试函数了。实现了下面接口所实现的功能：


class IDataPresistence{
public:
    //static IDataPresistence &CreatePresistence(IQueueUser *user);
    virtual bool DpGetMessage(DpMessageArryType &dpMsg,TaskType taskType) = 0;
    virtual bool DpGetWaitMessage(DpMessageArryType &dpMsg,TaskType taskType) = 0;
    virtual bool DpGetRunMessage(DpMessageArryType &dpMsg,TaskType taskType) = 0;
    virtual bool CreateDpMsgFile(TaskType taskType) = 0;
    virtual bool CreateDpMsgFile(const DpMessageType &dpMsg,TaskType taskType) = 0;
    //virtual bool CreateDpMsgFile(QueueType qt,const DpMessageType &dpMsg,TaskType taskType) = 0;
    virtual bool CreateWaitMsgFile(TaskType taskType) = 0;
    virtual bool CreateRunMsgFile(TaskType taskType) = 0;
   
};


测试结果OK。

回复

收藏2 举报

 楼主| keer_zu 发表于 2016-4-21 11:27 | 显示全部楼层
测试结果（第一项，写入文件）：

20160421112122.jpg

可以看到，成了所需文件，文件内容正确。

回复

收藏2 举报

 楼主| keer_zu 发表于 2016-4-21 11:28 | 显示全部楼层
测试结果（第二项，从产生的文件中读取，存入Vector容器）：

20160421112004.jpg

OK
回复

收藏2 举报

 楼主| keer_zu 发表于 2016-5-4 09:52 | 显示全部楼层
和新的可以做些对比。
回复

收藏2 举报

 楼主| keer_zu 发表于 2016-5-12 10:37 | 显示全部楼层
新的设计参看3
回复

收藏2 举报

 楼主| keer_zu 发表于 2020-4-24 13:28 | 显示全部楼层
设计
回复

收藏2 举报

返回列表 发新帖
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 注册

本版积分规则

keer_zu
个人签名：qq群：49734243 Email:zukeqiang@gmail.com

1493

主题

12963

帖子

55

粉丝
快速回复 在线客服 返回列表 返回顶部