21ic电子技术开发论坛 › 软件应用 › 平台与系统开发 › 一步一步完善我的设计（5）：各个模块编码码 ...
12下一页
返回列表 发新帖我要提问本帖赏金: 10.00元(功能说明)

一步一步完善我的设计（5）：各个模块编码码

[复制链接]
 楼主| keer_zu 发表于 2016-6-8 11:33 | 显示全部楼层 |阅读模式
编码, ic, ICE, SIM, SIMON
本帖最后由 keer_zu 于 2016-6-8 11:58 编辑

以下是各个模块编码：

@yyy71cj @dong_abc @ayb_ice
@Simon21ic   @21ic小喇叭
回复 赏

收藏2 举报

相关帖子
 楼主| keer_zu 发表于 2016-6-8 11:34 | 显示全部楼层
AddTask.h

复制
  1. #ifndef __ADD_TASK_H__
    

  2. #define __ADD_TASK_H__
    

  3. #include <stdio.h>
    

  4. #include <iostream>
    

  5. #include <string>
    

  6. #include <vector>
    

  7. #include "json/json.h"
    

  8. #include "InterfaceApi.h"
    

  9. #include "Disptacher.h"
    

  10. #include "Log4cxxWrapper.h"
    

  11. #include "Task.h"
    


  12. 


  13. 

  14. using namespace std;
    


  15. 

  16. class CommandDb;
    


  17. 


  18. 

  19. class AddTask
    

  20. {
    

  21.         AddTask *next; // 1. "next" pointer in the base class
    

  22.         
    

  23. protected:
    

  24.         vector<string> m_commandNames;
    

  25.         TaskDb *m_taskDb;
    

  26.         Disptacher *m_disptacher;
    

  27.         CommandDb* m_commandDb;
    


  28. 

  29. public:
    

  30.         AddTask();
    

  31.         
    

  32.         bool IsThisTaskType(const string cmdName)
    

  33.         {
    

  34.                 vector<string>::iterator it;
    

  35.                 
    

  36.                 for (it = m_commandNames.begin(); it != m_commandNames.end(); ++ it){
    

  37.                         if(cmdName == *it)
    

  38.                                 return true;
    

  39.                 }
    


  40. 

  41.                 return false;
    

  42.         }
    

  43.         virtual void GetInfo() = 0;
    


  44. 

  45.         virtual bool TaskSubmit(Task* task) = 0;
    

  46.                 
    

  47.         void setNext(AddTask *n)
    

  48.         {
    

  49.                 next = n;
    

  50.         }
    

  51.         void add(AddTask *n)
    

  52.         {
    

  53.                 if (next)
    

  54.                         next->add(n);
    

  55.                 else
    

  56.                         next = n;
    

  57.         }
    

  58.         virtual void AddSpacificTask(Json::Value& value,AppServerSession *appServerSion)
    

  59.         {
    

  60.                 if(next != NULL)
    

  61.                         next->AddSpacificTask(value,appServerSion);
    

  62.                 else {   // this command does not exist;
    

  63.                         printf("error");
    

  64.                         // TODO: log
    

  65.                 }
    

  66.         }
    


  67. 

  68.         Task* BuildBasicTask(Json::Value& value);
    

  69.         
    

  70.         bool DoAppResponse(string commandName,AppServerSession *session,Task* task);
    


  71. 

  72. };
    


  73. 

  74. class AddVideoTask : public AddTask
    

  75. {
    

  76.         AddVideoTask();
    

  77. public:
    

  78.         virtual void GetInfo(){}
    

  79.         virtual bool TaskSubmit(Task*);
    

  80.         static AddVideoTask& GetInstance();
    

  81.         virtual void AddSpacificTask(Json::Value& value,AppServerSession *appServerSion);        
    

  82. };
    


  83. 

  84. class AddDocTask : public AddTask
    

  85. {
    

  86.         AddDocTask();
    

  87. public:
    

  88.         virtual void GetInfo(){}
    

  89.         virtual bool TaskSubmit(Task*);
    

  90.         static AddDocTask& GetInstance();
    

  91.         virtual void AddSpacificTask(Json::Value& value,AppServerSession *appServerSion);
    

  92. };
    


  93. 

  94. class AddDpptTask : public AddTask
    

  95. {
    

  96.         AddDpptTask();
    

  97. public:
    

  98.         virtual void GetInfo(){}
    

  99.         virtual bool TaskSubmit(Task*);
    

  100.         static AddDpptTask& GetInstance();
    

  101.         virtual void AddSpacificTask(Json::Value& value,AppServerSession *appServerSion);
    

  102. };
    


  103. 

  104. class AddNoUseTsTask : public AddTask
    

  105. {
    

  106.         AddNoUseTsTask();
    

  107. public:
    

  108.         virtual void GetInfo(){}
    

  109.         virtual bool TaskSubmit(Task*);
    

  110.         static AddNoUseTsTask& GetInstance();
    

  111.         virtual void AddSpacificTask(Json::Value& value,AppServerSession *appServerSion);
    

  112. };
    


  113. 

  114. #endif
    


  115.
回复 赏

收藏2 举报

打赏榜单

21ic小喇叭 打赏了 10.00 元 2016-06-12
理由：分享打赏
 楼主| keer_zu 发表于 2016-6-8 11:35 | 显示全部楼层
AddTask.cpp

复制
  1. #include "AddTask.h"
    

  2. #include "TsManager.h"
    

  3. #include "CommandDb.h"
    

  4. #include "error.h"
    


  5. 


  6. 

  7. using namespace std;
    

  8. using namespace cdy;
    


  9. 

  10. //extern CommandDb GCommandDb;
    


  11. 

  12. extern TaskDocumentDb GTaskDocumentDb;
    

  13. extern TaskVideoDb GTaskVideoDb;
    

  14. extern TaskDpptDb GTaskDpptDb;
    

  15. extern TaskNoUseTsDb GTaskNoUseTsDb;
    


  16. 


  17. 

  18. //==========================  AddTask ===========================
    


  19. 

  20. AddTask::AddTask()
    

  21. {
    

  22.         next = NULL; 
    

  23.         m_commandDb = &CommandDb::GetInstance();//&GCommandDb;
    

  24. }
    


  25. 

  26. Task* AddTask::BuildBasicTask(Json::Value& value)
    

  27. {
    

  28.         Task *task;
    


  29. 

  30.         task = m_taskDb->GetTask();
    

  31.                 
    

  32.         if(!value["priority"].isNull() && value["priority"].isIntegral()){
    

  33.                 task->SetPriority(value["priority"].asInt());
    

  34.         } else {
    

  35.                 // TODO: LOG
    

  36.                 return NULL;
    

  37.         }
    


  38. 

  39.         if(!value["id"].isNull() && value["id"].isString()){
    

  40.                 task->SetTaskId(value["id"].asString());
    

  41.         } else {
    

  42.                 // TODO: LOG
    

  43.                 return NULL;
    

  44.         }
    


  45. 

  46.         task->Init();
    

  47.         task->SetCmdValue(value);
    

  48.         task->SetDisptacher(m_disptacher);
    

  49.         task->SetCommand(m_commandDb->GetCommand(value["command"].asString()));
    

  50.         
    


  51. 

  52.         if(!value["host"].isNull() && value["host"].isString()){
    

  53.                 task->m_appTargetIp = value["host"].asString();            
    

  54.         } else {
    

  55.                 // TODO: log
    

  56.                 return NULL;            
    

  57.         }   
    


  58. 

  59.         if(!value["port"].isNull() && value["port"].isIntegral()){
    

  60.                 task->m_appTargetPort = value["port"].asInt();             
    

  61.         } else {
    

  62.                 //dsLog.Log(FALSE,LOGGER_ERROR,"Error message from application client. No port. :%s, [%s][%s][%d]\n",strRecv.c_str(),__FILE__,__PRETTY_FUNCTION__,__LINE__);                                               
    

  63.                 return NULL; 
    

  64.         }
    


  65. 

  66.         return task;
    

  67. }
    


  68. 


  69. 

  70. bool AddTask::DoAppResponse(string commandName,AppServerSession *session,Task* task)
    

  71. {
    

  72.         string msg;
    

  73.         Command *cmd;
    

  74.         Json::Value valueAppRes;
    

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


  76. 

  77.         cmd = m_commandDb->GetCommand(commandName);
    

  78.         if(!cmd) 
    

  79.                 return false;
    

  80.         
    

  81.         if(m_disptacher->DuplicateTaskCheck(task->GetTaskId())){
    

  82.                 cmd->BuildAppResponse(valueAppRes,0,"");
    

  83.         } else {
    

  84.                 cmd->BuildAppResponse(valueAppRes,RET_E_REPEATED_TS_TRANS_TASK,"App task message id is repeated!");
    

  85.                 msg = valueAppRes.toStyledString() + '\0';
    

  86.                 session->SendMessage(msg);
    

  87.                 dsLog.Log(true,LOGGER_ERROR,"%s:%s:%d   App task message id is repeated!\n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  88.                 return false;
    

  89.         }
    


  90. 

  91.         msg = valueAppRes.toStyledString() + '\0';
    

  92.         session->SendMessage(msg);
    

  93.         
    

  94.         return true;
    

  95. }
    


  96. 

  97. //========================  AddVideoTask =========================
    

  98. AddVideoTask& AddVideoTask::GetInstance()
    

  99. {
    

  100.         static  AddVideoTask instance_;
    

  101.         return instance_;         
    

  102. }
    


  103. 


  104. 

  105. AddVideoTask::AddVideoTask()
    

  106. {
    

  107.         m_commandDb->GetCommandNameInSpecificTaskType(VideoTask,m_commandNames);
    

  108.         
    

  109.         m_taskDb = &GTaskVideoDb;
    

  110.         m_disptacher = &VideoDisptacher::GetInstance();//&GVideoDisptacher;
    

  111. }
    


  112. 

  113. void AddVideoTask::AddSpacificTask(Json::Value& value,AppServerSession *appServerSion)
    

  114. {
    

  115.         Task* task;
    


  116. 

  117.         if(IsThisTaskType(value["command"].asString())) {
    

  118.                 task = BuildBasicTask(value);
    

  119.                 if(!task) 
    

  120.                         return;
    

  121.                 
    

  122.                 if(!DoAppResponse(value["command"].asString(),appServerSion,task))
    

  123.                         return;
    


  124. 

  125.                 if(!TaskSubmit(task)){
    

  126.                         
    

  127.                 }
    


  128. 

  129.                 return;
    

  130.                 
    

  131.         } else {
    

  132.                 AddTask::AddSpacificTask(value,appServerSion);
    

  133.         }
    

  134. }
    


  135. 

  136. bool AddVideoTask::TaskSubmit(Task* task)
    

  137. {
    

  138.         return m_disptacher->Submit(task);
    

  139. }
    


  140. 


  141. 


  142. 


  143. 


  144. 

  145. //=========================  AddDocTask ==========================
    


  146. 

  147. AddDocTask& AddDocTask::GetInstance()
    

  148. {
    

  149.         static  AddDocTask instance_;
    

  150.         return instance_;         
    

  151. }
    


  152. 

  153. AddDocTask::AddDocTask()
    

  154. {
    

  155.         m_commandDb->GetCommandNameInSpecificTaskType(DocTask,m_commandNames);
    

  156.         
    

  157.         m_taskDb = &GTaskDocumentDb;
    


  158. 

  159.         m_disptacher = &DocDisptacher::GetInstance();//GDocDisptacher;
    

  160. }
    


  161. 

  162. void AddDocTask::AddSpacificTask(Json::Value& value,AppServerSession *appServerSion)
    

  163. {
    

  164.         Task* task;
    

  165.         
    

  166.         if(IsThisTaskType(value["command"].asString())) {
    

  167.                 task = BuildBasicTask(value);
    

  168.                 if(!task) 
    

  169.                         return;
    


  170. 

  171.                 TaskDocument* td = dynamic_cast<TaskDocument*>(task);
    

  172.                 
    

  173.                 if(!value["docServerType"].isNull()){
    

  174.                         if(value["docServerType"].isString() && 
    

  175.                                 (value["docServerType"].asString() == "LINUX" || 
    

  176.                                 value["docServerType"].asString() == "WPS" ||
    

  177.                                 value["docServerType"].asString() == "OFFICE" )
    

  178.                         )
    

  179.                                 td->SetIsSpecific(true);
    

  180.                         else
    

  181.                                 td->SetIsSpecific(false);
    

  182.                 } else {
    

  183.                         td->SetIsSpecific(false);
    

  184.                 }
    

  185.                 
    

  186.                 if(!DoAppResponse(value["command"].asString(),appServerSion,task))
    

  187.                         return;
    


  188. 

  189.                 if(!TaskSubmit(task)){
    

  190.                         
    

  191.                 }
    


  192. 

  193.                 return;
    

  194.         } else {
    

  195.                 AddTask::AddSpacificTask(value,appServerSion);
    

  196.         }
    

  197. }
    


  198. 

  199. bool AddDocTask::TaskSubmit(Task* task)
    

  200. {
    

  201.         return m_disptacher->Submit(task);
    

  202. }
    


  203. 


  204. 

  205. //========================  AddDpptTask ==========================
    

  206. AddDpptTask& AddDpptTask::GetInstance()
    

  207. {
    

  208.         static  AddDpptTask instance_;
    

  209.         return instance_;         
    

  210. }
    


  211. 

  212. AddDpptTask::AddDpptTask()
    

  213. {
    

  214.         m_commandDb->GetCommandNameInSpecificTaskType(DpptTask,m_commandNames);
    

  215.         
    

  216.         m_taskDb = &GTaskDpptDb;
    


  217. 

  218.         m_disptacher = &DpptDisptacher::GetInstance();//&GDpptDisptacher;
    

  219. }
    


  220. 

  221. void AddDpptTask::AddSpacificTask(Json::Value& value,AppServerSession *appServerSion)
    

  222. {
    

  223.         Task *task;
    

  224.         
    

  225.         if(IsThisTaskType(value["command"].asString())){
    

  226.                 task = BuildBasicTask(value);
    

  227.                 if(!task) 
    

  228.                         return;
    

  229.                 
    

  230.                 if(!DoAppResponse(value["command"].asString(),appServerSion,task))
    

  231.                         return;
    


  232. 

  233.                 if(!TaskSubmit(task)){
    

  234.                         
    

  235.                 }
    


  236. 

  237.                 return;
    

  238.         } else {
    

  239.                 AddTask::AddSpacificTask(value,appServerSion);
    

  240.         }
    

  241. }
    


  242. 

  243. bool AddDpptTask::TaskSubmit(Task* task)
    

  244. {
    

  245.         return m_disptacher->Submit(task);
    

  246. }
    


  247. 


  248. 


  249. 

  250. //====================== AddNoUseTsTask ===========================
    

  251. AddNoUseTsTask& AddNoUseTsTask::GetInstance()
    

  252. {
    

  253.         static  AddNoUseTsTask instance_;
    

  254.         return instance_;         
    

  255. }
    


  256. 

  257. AddNoUseTsTask::AddNoUseTsTask()
    

  258. {
    

  259.         m_commandDb->GetCommandNameInSpecificTaskType(NoTsTask,m_commandNames);
    

  260.         m_taskDb = &GTaskNoUseTsDb;
    

  261.         
    

  262. }
    


  263. 

  264. void AddNoUseTsTask::AddSpacificTask(Json::Value& value,AppServerSession *appServerSion)
    

  265. {
    

  266.         Task* task;
    

  267.         
    

  268.         if(IsThisTaskType(value["command"].asString())){
    

  269.                 task = BuildBasicTask(value);
    

  270.                 if(!task) 
    

  271.                         return;
    

  272.                 
    

  273.                 if(!DoAppResponse(value["command"].asString(),appServerSion,task))
    

  274.                         return;
    


  275. 

  276.                 if(!TaskSubmit(task)){
    

  277.                         
    

  278.                 }
    


  279. 

  280.                 return;
    

  281.         } else {
    

  282.                 AddTask::AddSpacificTask(value,appServerSion);
    

  283.         }
    

  284. }
    


  285. 

  286. bool AddNoUseTsTask::TaskSubmit(Task* task)
    

  287. {
    

  288.          Json::Value appResult;
    

  289.          bool ret;
    

  290.          string appResultMsg;
    

  291.          SessionManager& sm = SessionManager::GetInstance();
    

  292.          
    

  293.         Command* cmd = task->GetCommand();
    

  294.         
    

  295.         if(cmd->IsProvidedResult()){
    

  296.                 ret = cmd->BuildAppResult(task->GetCmdValue(),appResult);
    

  297.                 if(!ret){
    

  298.                         
    

  299.                         return false;
    

  300.                 }
    


  301. 

  302.                 appResultMsg = appResult.toStyledString();
    


  303. 

  304.                 sm.SendAppMessage(task->m_appTargetIp,task->m_appTargetPort,appResultMsg,task);
    

  305.         }
    

  306. }
    


  307. 


  308. 


  309.
回复 赏

收藏2 举报

 楼主| keer_zu 发表于 2016-6-8 11:36 | 显示全部楼层
CommandDb.h

复制
  1. #ifndef __COMMAND_DB_H__
    

  2. #define __COMMAND_DB_H__
    

  3. #include <string>
    

  4. #include "json/json.h"
    

  5. #include "TsManager.h"
    

  6. //#include "Task.h"
    


  7. 

  8. using namespace std;
    


  9. 


  10. 

  11. typedef enum{
    

  12.         DocTask = 0,
    

  13.         VideoTask,
    

  14.         DpptTask,
    

  15.         NoTsTask
    

  16. }TaskType;
    


  17. 

  18. class Command 
    

  19. {
    

  20. protected:
    

  21.         string m_commandName;
    

  22.         TsProperty m_tsProperty;
    

  23.         bool m_isUseTs;
    

  24.         TsType m_tsType;
    

  25.         TaskType m_taskType;
    

  26.         bool m_isProvidedResult;
    

  27.         string m_tsResultName;
    

  28. public:
    

  29.         Command();
    

  30.         virtual ~Command();
    


  31. 

  32.         string GetCommansName(){ return m_commandName;}
    

  33.         bool IsProvidedResult(){return m_isProvidedResult;}
    

  34.         TsType GetTsType(){return m_tsType;}
    

  35.         TaskType GetTaskType(){return m_taskType;}
    

  36.         string GetTaskResultName(){return m_tsResultName;};
    

  37.         
    

  38.         virtual bool BuildTsCmd(const Json::Value& appCmd,Json::Value& tsCmd);
    

  39.         virtual bool BuildTsResponse(const Json::Value& tsResult,Json::Value& tsResponse);
    

  40.         
    

  41.         virtual bool BuildAppResult(const Json::Value& tsResult,Json::Value& appResult); 
    

  42.         virtual bool BuildAppResult(ErrorInfo info,Json::Value& appResult);
    

  43.         virtual bool  BuildAppResponse(Json::Value& appResponse,unsigned int errorCode,string ErrorDetail) = 0; 
    

  44. };
    


  45. 


  46. 

  47. ///////////////////////////////// specific command //////////////////////////////////////
    

  48. class CommandServerStatus : public Command
    

  49. {
    

  50. public:
    

  51.         CommandServerStatus()
    

  52.         {
    

  53.                 m_commandName = "server_status_task";
    

  54.                 m_isUseTs = false;
    

  55.                 m_taskType = NoTsTask;
    

  56.                 m_isProvidedResult = true;
    

  57.         }
    

  58.         
    

  59.         ~CommandServerStatus();
    

  60.         virtual bool  BuildAppResponse(Json::Value& appResponse,unsigned int errorCode,string ErrorDetail);
    

  61.         virtual bool BuildAppResult(const Json::Value& appCmd,Json::Value& appResult);
    


  62. 

  63. };
    


  64. 


  65. 

  66. class CommandVideoMessage : public Command
    

  67. {
    

  68. public:
    

  69.         CommandVideoMessage()
    

  70.         {
    

  71.                 m_commandName = "video_message_task";
    

  72.                 m_isUseTs = true;
    

  73.                 m_tsType = TS_VIDEO;
    

  74.                 m_tsProperty = TS_LIGHT;
    

  75.                 m_taskType = VideoTask;
    

  76.                 m_isProvidedResult = true;
    

  77.                 m_tsResultName = "Message";
    

  78.         }
    


  79. 

  80.         ~CommandVideoMessage(){}
    


  81. 

  82.         virtual bool  BuildAppResponse(Json::Value& appResponse,unsigned int errorCode,string ErrorDetail);
    


  83. 

  84. };
    


  85. 


  86. 

  87. class CommandVideoTrans : public Command
    

  88. {
    

  89. public:
    

  90.         CommandVideoTrans()
    

  91.         {
    

  92.                 m_commandName = "video_trans_task";
    

  93.                 m_isUseTs = true;
    

  94.                 m_tsType = TS_VIDEO;
    

  95.                 m_tsProperty = TS_HEAVY;
    

  96.                 m_taskType = VideoTask;
    

  97.                 m_isProvidedResult = true;
    

  98.                 m_tsResultName = "Transfer";
    

  99.         }
    


  100. 

  101.         ~CommandVideoTrans(){}
    


  102. 

  103.         virtual bool  BuildAppResponse(Json::Value& appResponse,unsigned int errorCode,string ErrorDetail);
    

  104. };
    


  105. 

  106. class CommandPrintScreen : public Command
    

  107. {
    

  108. public:
    

  109.         CommandPrintScreen()
    

  110.         {
    

  111.                 m_commandName = "print_screen_task";
    

  112.                 m_isUseTs = true;
    

  113.                 m_tsType = TS_VIDEO;
    

  114.                 m_tsProperty = TS_LIGHT;
    

  115.                 m_taskType = VideoTask;
    

  116.                 m_isProvidedResult = true;
    

  117.                 m_tsResultName = "CapVideo";
    

  118.         }
    

  119.         ~CommandPrintScreen(){}
    


  120. 

  121.         virtual bool  BuildAppResponse(Json::Value& appResponse,unsigned int errorCode,string ErrorDetail);
    


  122. 

  123. };
    


  124. 

  125. class CommandVideoCut : public Command
    

  126. {
    

  127. public:
    

  128.         CommandVideoCut()
    

  129.         {
    

  130.                 m_commandName = "video_cut_task";
    

  131.                 m_isUseTs = true;
    

  132.                 m_tsType = TS_VIDEO;
    

  133.                 m_tsProperty = TS_LIGHT;
    

  134.                 m_taskType = VideoTask;
    

  135.                 m_isProvidedResult = true;
    

  136.                 m_tsResultName = "VideoCut";
    

  137.         }
    


  138. 

  139.         virtual bool  BuildAppResponse(Json::Value& appResponse,unsigned int errorCode,string ErrorDetail);
    


  140. 

  141. };
    


  142. 

  143. class CommandVideoMerge : public Command
    

  144. {
    

  145. public:
    

  146.         CommandVideoMerge()
    

  147.         {
    

  148.                 m_commandName = "video_merge_task";
    

  149.                 m_isUseTs = true;
    

  150.                 m_tsType = TS_VIDEO;
    

  151.                 m_tsProperty = TS_HEAVY;
    

  152.                 m_taskType = VideoTask;
    

  153.                 m_isProvidedResult = true;
    

  154.                 m_tsResultName = "VideoMerge";
    

  155.         }
    


  156. 

  157.         virtual bool  BuildAppResponse(Json::Value& appResponse,unsigned int errorCode,string ErrorDetail);
    


  158. 

  159. };
    


  160. 


  161. 

  162. class CommandDocTrans : public Command
    

  163. {
    

  164. public:
    

  165.         CommandDocTrans()
    

  166.         {
    

  167.                 m_commandName = "doc_trans_task";
    

  168.                 m_isUseTs = true;
    

  169.                 m_taskType = DocTask;
    

  170.                 m_isProvidedResult = true;
    

  171.                 
    

  172.         }
    

  173.         static bool GetServerTypes(vector<string>& CommandNames)
    

  174.         {
    

  175.                 CommandNames.push_back("DOC_WPS");
    

  176.                 CommandNames.push_back("DOC_OFFICE");
    

  177.                 CommandNames.push_back("DOC_LINUX");
    

  178.         }
    

  179.         virtual bool  BuildAppResponse(Json::Value& appResponse,unsigned int errorCode,string ErrorDetail);
    


  180. 

  181. };
    


  182. 


  183. 

  184. class CommandDynamicPptTrans : public Command
    

  185. {
    

  186. public:
    

  187.         CommandDynamicPptTrans()
    

  188.         {
    

  189.                 m_commandName = "dynamic_ppt_trans_task";
    

  190.                 m_isUseTs = true;
    

  191.                 m_tsType = TS_DYNAMIC_PPT;
    

  192.                 m_taskType = DpptTask;
    

  193.                 m_isProvidedResult = true;
    

  194.         }
    

  195.         static void GetServerTypes(vector<string>& CommandNames)
    

  196.         {
    

  197.                 CommandNames.push_back("DYNAMIC_PPT");
    

  198.         }
    

  199.         virtual bool  BuildAppResponse(Json::Value& appResponse,unsigned int errorCode,string ErrorDetail);
    


  200. 

  201. };
    


  202. 

  203. class CommandTaskProgress : public Command
    

  204. {
    

  205. public:
    

  206.         CommandTaskProgress()
    

  207.         {
    

  208.                 m_commandName = "task_progress_request";
    

  209.                 m_isUseTs = false;
    

  210.                 m_taskType = NoTsTask;
    

  211.                 m_isProvidedResult = true;
    

  212.         }
    


  213. 

  214.         virtual bool  BuildAppResponse(Json::Value& appResponse,unsigned int errorCode,string ErrorDetail);
    


  215. 

  216. };
    


  217. 

  218. /////////////////////////////////  CommandDb  ///////////////////////////////////////
    


  219. 

  220. class CommandDb
    

  221. {
    

  222.         CommandDb();
    

  223. public:
    

  224.         static CommandDb& GetInstance()
    

  225.         {
    

  226.                 static CommandDb instance_;
    

  227.                 return instance_;
    

  228.         }
    

  229.         ~CommandDb();
    

  230.         bool AddCommand(Command* cmd);
    

  231.         bool GetCommandNameInSpecificTaskType(TaskType taskType,vector<string>& CommandNames);
    

  232.         bool GetResultNameInSpecificTaskType(TaskType taskType,vector<string>& CommandNames);
    

  233.         Command* GetCommand(string cmdName);
    

  234. private:
    

  235.         map<string,Command*> m_commands;
    

  236. };
    

  237. #endif
    


  238.
回复 赏

收藏2 举报

 楼主| keer_zu 发表于 2016-6-8 11:37 | 显示全部楼层
CommandDb.cpp


复制
  1. #include "CommandDb.h"
    

  2. #include "TsManager.h"
    


  3. 

  4. CommandServerStatus GCmdServerStatus;
    

  5. CommandVideoMessage GCmdVideoMessage;
    

  6. CommandVideoTrans GCmdVideoTrans;
    

  7. CommandPrintScreen GCmdPrintScreen;
    

  8. CommandVideoMerge GCmdVideoMerge;
    

  9. CommandDocTrans GCmdDocTrans;
    

  10. CommandDynamicPptTrans GCmdDynamicPptTrans;
    


  11. 


  12. 

  13. //CommandDb GCommandDb;
    


  14. 


  15. 

  16. ////////////////////////////////////// Command //////////////////////////////////////////
    


  17. 

  18. Command::Command()
    

  19. {
    


  20. 

  21. }
    


  22. 

  23. Command::~Command()
    

  24. {
    


  25. 

  26. }
    


  27. 


  28. 

  29. bool Command::BuildTsCmd(const Json::Value& appCmd,Json::Value& tsCmd)
    

  30. {
    


  31. 

  32.         return true;
    

  33. }
    


  34. 

  35. bool Command::BuildTsResponse(const Json::Value& tsResult,Json::Value& tsResponse)
    

  36. {
    


  37. 

  38.         return true;
    

  39. }
    


  40. 


  41. 

  42. bool Command::BuildAppResult(ErrorInfo info,Json::Value& appResult)
    

  43. {
    


  44. 

  45.         return true;
    

  46. }
    


  47. 

  48. bool Command::BuildAppResult(const Json::Value& tsResult,Json::Value& appResult)
    

  49. {
    


  50. 

  51. }
    


  52. 


  53. 

  54. //////////////////////////////////// CommandServerStatus ///////////////////////////////////////////
    


  55. 

  56. //CommandServerStatus::CommandServerStatus()
    


  57. 


  58. 

  59. CommandServerStatus::~CommandServerStatus()
    

  60. {
    


  61. 

  62. }
    


  63. 

  64. bool  CommandServerStatus::BuildAppResponse(Json::Value& appResponse,unsigned int errorCode,string ErrorDetail)
    

  65. {
    


  66. 

  67.         return true;
    

  68. }
    


  69. 

  70. bool CommandServerStatus::BuildAppResult(const Json::Value& appCmd,Json::Value& appResult)
    

  71. {
    


  72. 

  73.         return true;
    

  74. }
    


  75. 

  76. ////////////////////////////////////// CommandVideoMessage //////////////////////////////////////
    

  77. bool  CommandVideoMessage::BuildAppResponse(Json::Value& appResponse,unsigned int errorCode,string ErrorDetail)
    

  78. {
    


  79. 

  80.         return true;
    

  81. }
    

  82. ////////////////////////////////////// CommandVideoTrans ///////////////////////////////////////
    

  83. bool  CommandVideoTrans::BuildAppResponse(Json::Value& appResponse,unsigned int errorCode,string ErrorDetail)
    

  84. {
    


  85. 

  86.         return true;
    

  87. }
    


  88. 

  89. ///////////////////////////////////// CommandPrintScreen ///////////////////////////////////////
    

  90. bool CommandPrintScreen::BuildAppResponse(Json::Value& appResponse,unsigned int errorCode,string ErrorDetail)
    

  91. {
    


  92. 

  93.         return true;
    

  94. }
    


  95. 

  96. ///////////////////////////////////// CommandVideoCut /////////////////////////////////////////
    

  97. bool CommandVideoCut::BuildAppResponse(Json::Value& appResponse,unsigned int errorCode,string ErrorDetail)
    

  98. {
    


  99. 

  100.         return true;
    

  101. }
    


  102. 


  103. 

  104. ///////////////////////////////////// CommandVideoMerge //////////////////////////////////////
    

  105. bool CommandVideoMerge::BuildAppResponse(Json::Value& appResponse,unsigned int errorCode,string ErrorDetail)
    

  106. {
    


  107. 

  108.         return true;
    

  109. }
    


  110. 


  111. 

  112. //////////////////////////////////// CommandDocTrans ////////////////////////////////////////
    

  113. bool CommandDocTrans::BuildAppResponse(Json::Value& appResponse,unsigned int errorCode,string ErrorDetail)
    

  114. {
    


  115. 

  116.         return true;
    

  117. }
    


  118. 

  119. /////////////////////////////////// CommandDynamicPptTrans //////////////////////////////////
    

  120. bool CommandDynamicPptTrans::BuildAppResponse(Json::Value& appResponse,unsigned int errorCode,string ErrorDetail)
    

  121. {
    


  122. 

  123.         return true;
    

  124. }
    


  125. 


  126. 

  127. ///////////////////////////////// CommandTaskProgress ///////////////////////////////////////
    

  128. bool CommandTaskProgress::BuildAppResponse(Json::Value& appResponse,unsigned int errorCode,string ErrorDetail)
    

  129. {
    


  130. 

  131.         return true;
    

  132. }
    


  133. 


  134. 

  135. /////////////////////////////////////// CommandDb ////////////////////////////////////////
    

  136. CommandDb::CommandDb()
    

  137. {
    

  138.         AddCommand(&GCmdServerStatus);
    

  139.         AddCommand(&GCmdVideoMessage);
    

  140.         AddCommand(&GCmdVideoTrans);
    

  141.         AddCommand(&GCmdPrintScreen);
    

  142.         AddCommand(&GCmdVideoMerge);
    

  143.         AddCommand(&GCmdDocTrans);
    

  144.         AddCommand(&GCmdDynamicPptTrans);
    

  145. }
    


  146. 

  147. CommandDb::~CommandDb()
    

  148. {
    


  149. 

  150. }
    


  151. 


  152. 

  153. bool CommandDb::AddCommand(Command* cmd)
    

  154. {
    

  155.         m_commands[cmd->GetCommansName()] = cmd;
    

  156.         return true;
    

  157. }
    


  158. 


  159. 

  160. bool CommandDb::GetCommandNameInSpecificTaskType(TaskType taskType,vector<string>& CommandNames)
    

  161. {
    

  162.         map<string,Command *>::iterator it;
    

  163.         
    

  164.         for(it=m_commands.begin();it!=m_commands.end();++it){
    

  165.                 if(it->second->GetTaskType() == taskType)
    

  166.                         CommandNames.push_back(it->first);
    

  167.         }
    


  168. 

  169.         return true;
    

  170. }
    


  171. 

  172. bool CommandDb::GetResultNameInSpecificTaskType(TaskType taskType,vector<string>& CommandNames)
    

  173. {
    

  174.         map<string,Command *>::iterator it;
    


  175. 

  176.         if(taskType == NoTsTask){
    

  177.                 
    

  178.                 return false;
    

  179.         }
    


  180. 

  181.         if(taskType == DpptTask){
    

  182.                 CommandDocTrans::GetServerTypes(CommandNames);
    

  183.                 return true;
    

  184.         }
    


  185. 

  186.         if(taskType == DocTask){
    

  187.                 CommandDynamicPptTrans::GetServerTypes(CommandNames);
    

  188.                 return true;
    

  189.         }
    

  190.         
    

  191.         for(it=m_commands.begin();it!=m_commands.end();++it){
    

  192.                 if(it->second->GetTaskType() == taskType)
    

  193.                         CommandNames.push_back(it->second->GetTaskResultName());
    

  194.         }
    


  195. 

  196.         return true;
    

  197. }
    


  198. 

  199. Command* CommandDb::GetCommand(string cmdName)
    

  200. {
    

  201.         if(m_commands.find(cmdName) != m_commands.end()){
    

  202.                 return m_commands[cmdName];
    

  203.         } else {
    

  204.                 return NULL;
    

  205.         }
    

  206. }
    


  207.
回复 赏

收藏2 举报

 楼主| keer_zu 发表于 2016-6-8 11:38 | 显示全部楼层
复制
  1. #ifndef __DISPTACHER_H__
    

  2. #define __DISPTACHER_H__
    


  3. 

  4. #include <stdio.h>
    

  5. #include <iostream>
    

  6. #include <string>
    

  7. #include <vector>
    

  8. #include "json/json.h"
    

  9. //#include "InterfaceApi.h"
    

  10. #include "TsQueue.h"
    

  11. #include "TaskQueue.h"
    


  12. 


  13. 

  14. class Disptacher {
    

  15. public:
    

  16.         Disptacher(){}
    


  17. 

  18.         bool DuplicateTaskCheck(string id)
    

  19.         {
    

  20.                 return !(m_taskRunQueue->CheckSameTaskId(id) || m_taskWaitQueue->CheckSameTaskId(id));
    

  21.         }
    


  22. 

  23.         virtual bool Submit(Task *task) = 0;
    


  24. 

  25. protected:
    

  26.         TaskWaitQueue* m_taskWaitQueue;
    

  27.         TaskRunQueue* m_taskRunQueue;
    

  28.         map<string,TsQueue*>m_tsQueues;
    

  29.         //vector<string> m_commandNames;
    


  30. 

  31. };
    


  32. 

  33. class DocDisptacher : public Disptacher
    

  34. {
    

  35.         map<int,string> m_tsPriority;
    

  36.         DocDisptacher();
    

  37. public:
    

  38.         static DocDisptacher& GetInstance();
    

  39.         virtual bool Submit(Task *task);
    


  40. 

  41.         bool GetDocTsPriority();
    

  42. };
    


  43. 

  44. class VideoDisptacher : public Disptacher
    

  45. {
    

  46.         VideoDisptacher();
    

  47. public:
    

  48.         static VideoDisptacher& GetInstance();
    

  49.         virtual bool Submit(Task *task);
    

  50. };
    


  51. 

  52. class DpptDisptacher : public Disptacher
    

  53. {
    

  54.         DpptDisptacher();
    

  55. public:
    

  56.         static DpptDisptacher& GetInstance();
    

  57.         virtual bool Submit(Task *task);
    

  58. };
    


  59. 

  60. #endif
    


  61.

Disptacher.h
回复 赏

收藏2 举报

 楼主| keer_zu 发表于 2016-6-8 11:39 | 显示全部楼层
Disptacher.cpp


复制
  1. #include "Disptacher.h"
    

  2. #include "AddTask.h"
    

  3. //#include "TsManager.h"
    

  4. //#include "CommandDb.h"
    

  5. #include "error.h"
    

  6. #include "Log4cxxWrapper.h"
    

  7. #include <algorithm>
    

  8. #include <memory>
    

  9. #include "ConfigManager.h"
    


  10. 

  11. #include "CommandDb.h"
    


  12. 


  13. 


  14. 

  15. //using namespace std;
    

  16. using namespace cdy;
    


  17. 


  18. 

  19. extern TaskWaitQueue GDocTaskWaitQueue;
    

  20. extern TaskWaitQueue GVideoTaskWaitQueue;
    

  21. extern TaskWaitQueue GDpptTaskWaitQueue;
    

  22. extern TaskWaitQueue GNoTsTaskTaskWaitQueue;
    


  23. 


  24. 

  25. extern TaskRunQueue GDocTaskRunQueue;
    

  26. extern TaskRunQueue GVideoTaskRunQueue;
    

  27. extern TaskRunQueue GDpptTaskRunQueue;
    

  28. extern TaskRunQueue GNoTsTaskRunQueue;
    


  29. 

  30. extern TsQueue GVideoTsQueue;
    

  31. extern TsQueue GDocOpenofficeTsQueue;
    

  32. extern TsQueue GDocWpsTsQueue;
    

  33. extern TsQueue GDocOfficeTsQueue;
    

  34. extern TsQueue GDpptTsQueue;
    


  35. 


  36. 


  37. 

  38. string ToUpperString(string str)  
    

  39. {  
    

  40.         string tmpstr= str;
    

  41.         transform(tmpstr.begin(), tmpstr.end(), tmpstr.begin(), (int (*)(int))toupper);  
    

  42.         return tmpstr;
    

  43. }  
    

  44. string ToLowerString(string str)  
    

  45. {  
    

  46.         string tmpstr= str;
    

  47.         transform(tmpstr.begin(), tmpstr.end(), tmpstr.begin(), (int (*)(int))tolower);  
    

  48.         return tmpstr;
    

  49. }
    


  50. 


  51. 

  52. bool CheckNoSameName(map<int,string>& mp, int count)
    

  53. {
    

  54.         for(int i=0;i<count-1;i++){
    

  55.                 for(int j=i+1;j<count;j++){
    

  56.                         if(mp[i] == mp[j]){
    

  57.                                 return false;
    

  58.                         }
    

  59.                 }
    

  60.         }
    

  61.         return true;
    

  62. }
    


  63. 


  64. 

  65. //////////////////////////////// Disptacher //////////////////////////////////
    


  66. 


  67. 


  68. 


  69. 

  70. //////////////////////////////// DocDisptacher ///////////////////////////////
    


  71. 

  72. DocDisptacher::DocDisptacher()
    

  73. {
    

  74.         m_taskWaitQueue = &GDocTaskWaitQueue;
    

  75.         m_taskRunQueue = &GDocTaskRunQueue;
    


  76. 

  77.         GetDocTsPriority();
    

  78.         
    

  79.         m_tsQueues["linux"] = &GDocOpenofficeTsQueue;
    

  80.         m_tsQueues["wps"] = &GDocWpsTsQueue;
    

  81.         m_tsQueues["office"] = &GDocOfficeTsQueue;
    


  82. 

  83.         GetDocTsPriority();
    

  84. }
    


  85. 

  86. DocDisptacher& DocDisptacher::GetInstance()
    

  87. {
    

  88.         static DocDisptacher instance_;
    

  89.         return instance_;
    

  90. }
    


  91. 

  92. bool DocDisptacher::Submit(Task *task)
    

  93. {
    

  94.         TsQueue* tsq;
    

  95.         TransServer* ts = NULL;
    

  96.         int i;
    

  97.         Json::Value tsCmd;
    

  98.         Json::Value appResponse;
    

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

  100.         Command* cmd;
    

  101.         bool ret;
    

  102. /*
    

  103.         if(task->m_triedTimes >= task->m_maxTryTimes){
    

  104.                 cmd = task->GetCommand();
    

  105.                 
    

  106.                 ret = cmd->BuildAppResponse(appResponse,errorCode, string ErrorDetail);
    

  107.         }
    

  108. */        
    

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

  110.                 tsq = m_tsQueues[m_tsPriority[0]];
    

  111.                 ts = tsq->GetTsIdle();
    

  112.                 if(ts){
    

  113.                         task->m_alreadyTriedTsType.push_back(i);
    

  114.                         task->m_alreadyTriedTsId.push_back(ts->GetId());
    


  115. 

  116.                         break;
    

  117.                 }
    

  118.         }
    


  119. 

  120.         if(ts){
    

  121.                 Command* cmd = task->GetCommand();
    

  122.                 if(!cmd->BuildTsCmd(task->GetCmdValue(),tsCmd)){
    

  123.                         dsLog.Log(true,LOGGER_ERROR,"build doc ts cmd error !!!!!, [%s][%s][%d]\n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  124.                         return false;
    

  125.                 }
    


  126. 

  127.                 ts->SetTask(task);
    


  128. 

  129.                 string tsMsg = tsCmd.toStyledString() + '\0';
    

  130.                 TsSession* session = ts->GetSession();
    

  131.                 session->SendMessage(tsMsg);
    

  132.                 task->m_triedTimes += 1;
    

  133.                 m_taskRunQueue->PushTask(task,session);
    

  134.                 
    

  135.         } else {
    

  136.                 m_taskWaitQueue->PushTask(task);
    

  137.         }
    

  138. }
    


  139. 

  140. #define MAX_DOCUMENT_SEVER_TYPE_NUM 3
    

  141. bool DocDisptacher::GetDocTsPriority()
    

  142. {
    

  143.         Json::Value  value;  
    

  144.         std::auto_ptr<Json::Reader> pJsonParser(new Json::Reader(Json::Features::strictMode())); 
    


  145. 

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


  147. 

  148.         string strTsPriority = ""TsPriority":" + ConfigManager::GetTsPriority();
    

  149.         string strWholeJson = "{"+strTsPriority+"}";
    

  150.         //string strPriorityArray[MAX_DOCUMENT_SEVER_TYPE_NUM];
    


  151. 

  152.         map<string,TsQueue*> tsQueue;
    

  153.         
    

  154.         if(pJsonParser->parse(strWholeJson,value)){
    

  155.                 const Json::Value TsPriority = value["TsPriority"];
    

  156.  
    

  157.                 if((!value["TsPriority"].isNull()) && (value["TsPriority"].isArray()) && (MAX_DOCUMENT_SEVER_TYPE_NUM == TsPriority.size()) ){
    

  158.                         for (unsigned int i = 0; i < TsPriority.size(); i++){
    

  159.                                 if(TsPriority[i].isString()){
    

  160.                                         if(( "LINUX" == ToUpperString(TsPriority[i].asString()))||( "OFFICE" == ToUpperString(TsPriority[i].asString()))||( "WPS" == ToUpperString(TsPriority[i].asString()))){
    

  161.                                                 m_tsPriority[i] = TsPriority[i].asString();
    

  162.                                                 
    

  163.                                         } else {
    

  164.                                                 dsLog.Log(true,LOGGER_ERROR,"error config file. Invalid TsPriority format  . :%s , [%s][%s][%d]\n",strTsPriority.c_str(),__FILE__,__PRETTY_FUNCTION__,__LINE__);               
    

  165.                                                 return false;
    

  166.                                         }
    

  167.                                 } else {
    

  168.                                         dsLog.Log(true,LOGGER_ERROR,"error config file. Invalid TsPriority format  . :%s , [%s][%s][%d]\n",strTsPriority.c_str(),__FILE__,__PRETTY_FUNCTION__,__LINE__);               
    

  169.                                         return false;            
    

  170.                                 }
    

  171.                         }
    

  172.                         if(!CheckNoSameName(m_tsPriority,MAX_DOCUMENT_SEVER_TYPE_NUM)){
    

  173.                                 dsLog.Log(true,LOGGER_ERROR,"error config file. Invalid TsPriority format  . :%s , [%s][%s][%d]\n",strTsPriority.c_str(),__FILE__,__PRETTY_FUNCTION__,__LINE__);               
    

  174.                                 return false;                
    

  175.                         }
    

  176.                 } else{
    

  177.   
    

  178.                         dsLog.Log(true,LOGGER_ERROR,"error config file. Invalid TsPriority format . :%s , [%s][%s][%d]\n",strTsPriority.c_str(),__FILE__,__PRETTY_FUNCTION__,__LINE__);               
    

  179.                         return false;            
    

  180.                 }
    


  181. 

  182.         } else{
    

  183.                 dsLog.Log(true,LOGGER_ERROR,"error config file. Invalid TsPriority format  . :%s , [%s][%s][%d]\n",strTsPriority.c_str(),__FILE__,__PRETTY_FUNCTION__,__LINE__);               
    

  184.                 return false;            
    

  185.         }    
    


  186. 

  187.         return true;
    


  188. 

  189. }
    


  190. 

  191. ///////////////////////////////// VideoDisptacher /////////////////////////////
    


  192. 

  193. VideoDisptacher::VideoDisptacher()
    

  194. {
    

  195.         m_taskWaitQueue = &GVideoTaskWaitQueue;
    

  196.         m_taskRunQueue = &GVideoTaskRunQueue;
    

  197.         m_tsQueues["Video1"] = &GVideoTsQueue;
    

  198. }
    


  199. 

  200. VideoDisptacher& VideoDisptacher::GetInstance()
    

  201. {
    

  202.         static VideoDisptacher instance_;
    

  203.         return instance_;
    

  204. }
    


  205. 

  206. bool VideoDisptacher::Submit(Task *task)
    

  207. {
    

  208.         TsQueue* tsq;
    

  209.         TransServer* ts = NULL;
    

  210.         Json::Value tsCmd;
    

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

  212.         
    


  213. 

  214.         tsq = m_tsQueues["Video1"];
    

  215.         ts = tsq->GetTsIdle();
    

  216.         if(ts){
    

  217.                 task->m_alreadyTriedTsId.push_back(ts->GetId());
    


  218. 

  219.                 Command* cmd = task->GetCommand();
    

  220.                 if(!cmd->BuildTsCmd(task->GetCmdValue(),tsCmd)){
    

  221.                         dsLog.Log(true,LOGGER_ERROR,"build doc ts cmd error !!!!!, [%s][%s][%d]\n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  222.                         return false;
    

  223.                 } 
    


  224. 

  225.                 string tsMsg = tsCmd.toStyledString() + '\0';
    

  226.                 TsSession* session = ts->GetSession();
    

  227.                 session->SendMessage(tsMsg);
    

  228.                 task->m_triedTimes += 1;
    

  229.                 m_taskRunQueue->PushTask(task,session);
    

  230.         } else {
    

  231.                 m_taskWaitQueue->PushTask(task);
    

  232.         }
    


  233. 

  234. }
    


  235. 

  236. //////////////////////////////// DpptDisptacher ///////////////////////////////
    


  237. 

  238. DpptDisptacher::DpptDisptacher()
    

  239. {
    

  240.         m_taskWaitQueue = &GDpptTaskWaitQueue;
    

  241.         m_taskRunQueue = &GDpptTaskRunQueue;
    

  242.         m_tsQueues["Dppt1"] = &GDpptTsQueue;
    

  243. }
    


  244. 


  245. 

  246. DpptDisptacher& DpptDisptacher::GetInstance()
    

  247. {
    

  248.         static DpptDisptacher instance_;
    

  249.         return instance_;
    

  250. }
    


  251. 


  252. 

  253. bool DpptDisptacher::Submit(Task *task)
    

  254. {
    

  255.         TsQueue* tsq;
    

  256.         TransServer* ts = NULL;
    

  257.         Json::Value tsCmd;
    

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

  259.         
    


  260. 

  261.         tsq = m_tsQueues["Dppt1"];
    

  262.         ts = tsq->GetTsIdle();
    

  263.         if(ts){
    

  264.                 task->m_alreadyTriedTsId.push_back(ts->GetId());
    


  265. 

  266.                 Command* cmd = task->GetCommand();
    

  267.                 if(!cmd->BuildTsCmd(task->GetCmdValue(),tsCmd)){
    

  268.                         dsLog.Log(true,LOGGER_ERROR,"build doc ts cmd error !!!!!, [%s][%s][%d]\n",__FILE__,__PRETTY_FUNCTION__,__LINE__);
    

  269.                         return false;
    

  270.                 } 
    


  271. 

  272.                 string tsMsg = tsCmd.toStyledString() + '\0';
    

  273.                 TsSession* session = ts->GetSession();
    

  274.                 session->SendMessage(tsMsg);
    

  275.                 task->m_triedTimes += 1;
    

  276.                 m_taskRunQueue->PushTask(task,session);
    

  277.         } else {
    

  278.                 m_taskWaitQueue->PushTask(task);
    

  279.         }
    

  280. }
    


  281.
回复 赏

收藏2 举报

 楼主| keer_zu 发表于 2016-6-8 11:40 | 显示全部楼层
Message.h



复制
  1. #ifndef __MESSAGE_H__
    

  2. #define __MESSAGE_H__
    


  3. 

  4. #include "InterfaceApi.h"
    

  5. #include "AddTask.h"
    

  6. #include "TaskResult.h"
    

  7. //#include "TsInterface.h"
    


  8. 

  9. typedef enum{
    

  10.         TsRegistMsg = 0,
    

  11.         TsResultMsg,
    

  12.         TsUpdateMsg,
    

  13.         TsLinkResponse
    

  14. }TsMsgType;
    


  15. 


  16. 

  17. class Message
    

  18. {
    

  19. public:
    

  20.         Message(){}
    

  21.         virtual ~Message(){}
    

  22. };
    


  23. 

  24. class AppMessage : public Message
    

  25. {
    

  26. public:
    

  27.         
    

  28. };
    


  29. 

  30. class TsMessage : public Message
    

  31. {
    

  32. protected:
    

  33.         string m_type;
    

  34.         TsMsgType m_tsMsgType;
    

  35.         string m_serverType;
    

  36. public:
    

  37.         virtual ~TsMessage(){}
    

  38.         TsMessage(){}
    

  39.         TsMsgType GetTsMsgType(){return m_tsMsgType;}
    


  40. 

  41.         string GetServerType(){return m_serverType;}
    

  42.         
    

  43. };
    


  44. 


  45. 

  46. class TsResultMessage : public TsMessage
    

  47. {
    


  48. 

  49. public:
    

  50.         TsResultMessage(string serverType)
    

  51.         {
    

  52.                 m_type = "TransResult";
    

  53.                 m_tsMsgType = TsUpdateMsg;
    

  54.                 m_serverType = serverType;
    

  55.         }
    

  56. public:
    

  57.         //string m_serverType;
    

  58. };
    


  59. 

  60. class TsRegistMessage : public TsMessage
    

  61. {
    


  62. 

  63. public:
    

  64.         TsRegistMessage(string serverType)
    

  65.         {
    

  66.                 m_type = "SvrRegister";
    

  67.                 m_tsMsgType = TsRegistMsg;
    

  68.                 m_serverType = serverType;
    

  69.         }
    


  70. 

  71.         bool BuildResponse(int errCode,const string& errorDetial,string& response);
    

  72. };
    


  73. 


  74. 


  75. 

  76. class TsUpdateMessage : public TsMessage
    

  77. {
    

  78. public:
    

  79.         TsUpdateMessage(string serverType)
    

  80.         {
    

  81.                 m_type = "TaskProgress";
    

  82.                 m_tsMsgType = TsUpdateMsg;
    

  83.                 m_serverType = serverType;
    

  84.         }
    

  85. };
    


  86. 

  87. class TsMessageDb
    

  88. {
    

  89.         TsMessageDb();
    

  90. public:
    

  91.         static TsMessageDb& GetInstance()
    

  92.         {
    

  93.                 static TsMessageDb instance_;
    

  94.                 return instance_;
    

  95.         }
    

  96.         bool AddMessage(TsMessage *msg);
    

  97.         bool GetServerTypeInSpecificType(TsMsgType msgType,vector<string>& tsMessages);
    

  98.         TsMessage* GetMessage(TsMsgType msgType,string serverType);
    

  99. private:
    

  100.         vector<TsMessage *> m_tsMessages;
    

  101. };
    


  102. 


  103. 

  104. class TsMessageHandle
    

  105. {
    

  106.         TsMessageHandle* next; 
    

  107. public:
    

  108.         TsMessageHandle(){}
    

  109.         bool IsThisMsg(string type)
    

  110.         {
    

  111.                 if(type == m_type)
    

  112.                         return true;
    

  113.                 else
    

  114.                         return false;
    

  115.         }
    

  116.         void setNext(TsMessageHandle *n)
    

  117.         {
    

  118.                 next = n;
    

  119.         }
    

  120.         void add(TsMessageHandle *n)
    

  121.         {
    

  122.                 if (next)
    

  123.                         next->add(n);
    

  124.                 else
    

  125.                         next = n;
    

  126.         }
    

  127.         virtual void SpacificHandle(Json::Value& value,TsSession* tsSession)
    

  128.         {
    

  129.                 if(next != NULL)
    

  130.                         next->SpacificHandle(value,tsSession);
    

  131.                 else {   // this command does not exist;
    

  132.                         printf("error");
    

  133.                         // TODO: log
    

  134.                 }
    

  135.         }
    

  136. protected:
    

  137.         string m_type;
    

  138. };
    


  139. 

  140. class TsRegistMessageHandle : public TsMessageHandle
    

  141. {
    

  142.         ITsRegister* m_register;
    

  143.         
    


  144. 

  145.         TsRegistMessageHandle(ITsRegister* reg)
    

  146.         {
    

  147.                 m_register = reg;
    

  148.                 m_type = "SvrRegister";
    

  149.         }
    

  150. public:
    

  151.         virtual void SpacificHandle(Json::Value& value,TsSession* tsSession);
    

  152.         static TsRegistMessageHandle& GetInstance(ITsRegister* reg)
    

  153.         {
    

  154.                 static  TsRegistMessageHandle instance_(reg);
    

  155.                 return instance_;         
    

  156.         }
    

  157. };
    


  158. 

  159. class TsResultMessageHandle : public TsMessageHandle
    

  160. {
    

  161.         //ITaskResult* m_taskResult;
    

  162.         TaskResult* m_taskResult;
    

  163.         TsResultMessageHandle(/*ITaskResult* tr*/) 
    

  164.         {
    

  165.                 //m_taskResult = tr;
    

  166.                 m_type = "TransResult";
    

  167.                 m_taskResult = &DocTaskResult::GetInstance();
    


  168. 

  169.                 VideoTaskResult &videoTaskResult = VideoTaskResult::GetInstance();
    

  170.                 DpptTaskResult &dpptTaskResult = DpptTaskResult::GetInstance();
    


  171. 

  172.                 m_taskResult->add(&videoTaskResult);
    

  173.                 m_taskResult->add(&dpptTaskResult);
    

  174.         }
    

  175. public:
    

  176.         virtual void SpacificHandle(Json::Value& value,TsSession* tsSession);
    

  177.         static TsResultMessageHandle& GetInstance()
    

  178.         {
    

  179.                 static  TsResultMessageHandle instance_;
    

  180.                 return instance_;         
    

  181.         }
    

  182. };
    


  183. 

  184. class TsUpdateMessageHandle : public TsMessageHandle
    

  185. {
    

  186.         ITsUpdateInfo* m_updataInfo;
    

  187.         TsUpdateMessageHandle(ITsUpdateInfo* ui):m_updataInfo(ui)
    

  188.                 {m_type = "TaskProgress";}
    

  189. public:
    

  190.         virtual void SpacificHandle(Json::Value& value,TsSession* tsSession);
    

  191.         static TsUpdateMessageHandle& GetInstance(ITsUpdateInfo* ui)
    

  192.         {
    

  193.                 static  TsUpdateMessageHandle instance_(ui);
    

  194.                 return instance_;         
    

  195.         }
    

  196. };
    


  197. 

  198. class MessageAnalyzer
    

  199. {
    

  200. public:
    

  201.         
    

  202. };
    


  203. 

  204. class TsMessageAnalyzer : public MessageAnalyzer,public ITsNewFrame
    

  205. {
    

  206.         TsMessageAnalyzer();
    

  207.         //TaskResult* m_taskResult;
    

  208.         TsMessageHandle* m_messageHandle;
    

  209. public:
    

  210.         ~TsMessageAnalyzer();
    

  211.         static TsMessageAnalyzer& GetInstance();
    

  212.         virtual void OnNewFrame(TsSession* tsServerSion,const string frame);
    

  213. };
    


  214. 

  215. class AppMessageAnalyzer : public MessageAnalyzer,public IAppNewFrame
    

  216. {
    

  217.         AppMessageAnalyzer();
    

  218.         AddTask* m_addTask;
    

  219. public:
    

  220.         ~AppMessageAnalyzer();
    

  221.         static AppMessageAnalyzer& GetInstance();
    

  222.         virtual void OnNewFrame(AppServerSession *appServerSion,string frame);
    

  223. };
    


  224. 


  225. 

  226. class testITsRegister : public ITsRegister
    

  227. {
    

  228. public:
    

  229.         virtual void OnRegister(Json::Value& value,TsSession *session){}
    

  230. };
    


  231. 

  232. #endif
回复 赏

收藏2 举报

 楼主| keer_zu 发表于 2016-6-8 11:41 | 显示全部楼层
Message.cpp



复制
  1. #include "Message.h"
    

  2. #include <memory>.
    

  3. #include "json/json.h"
    

  4. #include "Log4cxxWrapper.h"
    

  5. #include "TsManager.h"
    


  6. 

  7. using namespace std;
    


  8. 

  9. TsResultMessage  tsDpptResult("DYNAMIC_PPT");
    

  10. TsResultMessage  tsDocWindowsResult("DOC_WINDOWS");
    

  11. TsResultMessage  tsDocResult("DOC");
    

  12. TsResultMessage  tsDocWpsResult("DOC_WPS");
    

  13. TsResultMessage  tsTransferResult("Transfer");
    

  14. TsResultMessage  tsVideoCutResult("VideoCut");
    

  15. TsResultMessage  tsVideoMergeResult("VideoMerge");
    

  16. TsResultMessage  tsCapVideoResult("CapVideo");
    

  17. TsResultMessage  tsMessageResult("Message");
    

  18. TsRegistMessage  tsRegistMessage("");
    

  19. //TsLinkResponseMessage tsLinkResponseMessage("");
    

  20. TsUpdateMessage tsUpdateMessage("");
    


  21. 

  22. //////////////////////////////// TsRegistMessage /////////////////////////////////////////
    


  23. 

  24. bool TsRegistMessage::BuildResponse(int errCode,const string& errorDetial,string& response)
    

  25. {
    


  26. 

  27.         return true;
    

  28. }
    


  29. 

  30. TsMessageDb::TsMessageDb()
    

  31. {
    

  32.         AddMessage(&tsDpptResult);
    

  33.         AddMessage(&tsDocWindowsResult);
    

  34.         AddMessage(&tsDocResult);
    

  35.         AddMessage(&tsDocWpsResult);
    

  36.         AddMessage(&tsTransferResult);
    

  37.         AddMessage(&tsVideoCutResult);
    

  38.         AddMessage(&tsVideoMergeResult);
    

  39.         AddMessage(&tsCapVideoResult);
    

  40.         AddMessage(&tsMessageResult);
    

  41.         AddMessage(&tsRegistMessage);
    

  42. //        AddMessage(&tsLinkResponseMessage);
    

  43.         AddMessage(&tsUpdateMessage);
    

  44. }
    


  45. 

  46. bool TsMessageDb::AddMessage(TsMessage * msg)
    

  47. {
    

  48.         m_tsMessages.push_back(msg);
    

  49.         return true;
    

  50. }
    


  51. 

  52. bool TsMessageDb::GetServerTypeInSpecificType(TsMsgType msgType, vector < string > & tsMessages)
    

  53. {
    

  54.         vector<TsMessage *>::iterator t ;
    

  55.         for(t=m_tsMessages.begin(); t!=m_tsMessages.end(); t++){
    

  56.                 if((*t)->GetTsMsgType() == msgType)
    

  57.                         tsMessages.push_back((*t)->GetServerType());
    

  58.         }
    

  59.         
    

  60.         return true;
    

  61. }
    


  62. 

  63. TsMessage* TsMessageDb::GetMessage(TsMsgType msgType, string serverType)
    

  64. {
    

  65.         TsMessage* message = NULL;
    

  66.         vector<TsMessage *>::iterator t ;
    

  67.         for(t=m_tsMessages.begin(); t!=m_tsMessages.end(); t++){
    

  68.                 if((*t)->GetTsMsgType() == msgType && (*t)->GetServerType() == serverType){
    

  69.                         message = *t;
    

  70.                         break;
    

  71.                 }
    

  72.         }
    

  73.         
    

  74.         return message;
    

  75. }
    

  76. //////////////////////////////// TsRegistMessageHandle /////////////////////////////
    


  77. 

  78. void TsRegistMessageHandle::SpacificHandle(Json::Value& value,TsSession* tsSession)
    

  79. {
    

  80.         if(IsThisMsg(value["type"].asString())){
    

  81.                 if(m_register != NULL){
    

  82.                         m_register->OnRegister(value, tsSession);
    

  83.                 }
    

  84.         } else {
    

  85.                 TsMessageHandle::SpacificHandle(value,tsSession);
    

  86.         }
    

  87. }
    


  88. 


  89. 

  90. //////////////////////////////// TsResultMessageHandle /////////////////////////////////
    

  91. void TsResultMessageHandle::SpacificHandle(Json::Value& value,TsSession* tsSession)
    

  92. {
    

  93.         if(IsThisMsg(value["type"].asString())){
    

  94.                 if((!value["servertype"].isNull()) &&  (value["servertype"].isString())){
    

  95.                         m_taskResult->SpacificTaskResult(value,tsSession);
    

  96.                 } else {
    


  97. 

  98.                 }
    

  99.         } else {
    

  100.                 TsMessageHandle::SpacificHandle(value,tsSession);
    

  101.         }
    

  102. }
    


  103. 

  104. ////////////////////////////// TsUpdateMessageHandle //////////////////////////////////
    

  105. void TsUpdateMessageHandle::SpacificHandle(Json::Value& value,TsSession* tsSession)
    

  106. {
    

  107.         if(IsThisMsg(value["type"].asString())){
    

  108.                 if(m_updataInfo!= NULL){
    

  109.                         m_updataInfo->OnUpdateInfo(value, tsSession);
    

  110.                 }
    

  111.         } else {
    

  112.                 TsMessageHandle::SpacificHandle(value,tsSession);
    

  113.         }
    

  114. }
    


  115. 

  116. ////////////////////////////////  TsMessageAnalyzer  ///////////////////////////////
    

  117. //class TsRegister;
    

  118. TsRegister testITR;
    


  119. 

  120. TsMessageAnalyzer::TsMessageAnalyzer()
    

  121. {
    


  122. 

  123.         m_messageHandle = &TsRegistMessageHandle::GetInstance(&testITR);
    


  124. 

  125.         TsResultMessageHandle& resultHandle = TsResultMessageHandle::GetInstance();
    

  126.         TsUpdateMessageHandle& updateHandle = TsUpdateMessageHandle::GetInstance(NULL);
    


  127. 

  128.         m_messageHandle->add(&resultHandle);
    

  129.         m_messageHandle->add(&updateHandle);
    

  130.         
    

  131. }
    


  132. 

  133. TsMessageAnalyzer::~TsMessageAnalyzer()
    

  134. {
    


  135. 

  136. }
    


  137. 

  138. TsMessageAnalyzer& TsMessageAnalyzer::GetInstance()
    

  139. {
    

  140.         static  TsMessageAnalyzer instance_;
    

  141.         return instance_; 
    

  142. }
    


  143. 

  144. void  TsMessageAnalyzer::OnNewFrame(TsSession* tsServerSion,const string frame)
    

  145. {
    

  146.         Json::Value  value;  
    

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


  148. 

  149.         if(tsServerSion == NULL){
    


  150. 

  151.                 return;
    

  152.         }
    


  153. 

  154.         std::auto_ptr<Json::Reader> pJsonParser(new Json::Reader(Json::Features::strictMode())); 
    


  155. 

  156.         if(pJsonParser->parse(frame,value)){
    

  157.                 if((!value["type"].isNull()) &&  (value["type"].isString())){
    

  158.                         m_messageHandle->SpacificHandle( value, tsServerSion);
    

  159.                 } else {
    

  160.                         
    

  161.                 }
    

  162.         }
    

  163. }
    


  164. 

  165. ////////////////////////////////  AppMessageAnalyzer  //////////////////////////////
    


  166. 

  167. AppMessageAnalyzer::AppMessageAnalyzer()
    

  168. {
    

  169.         m_addTask = &AddDocTask::GetInstance();
    

  170.         AddVideoTask &addVideoTask = AddVideoTask::GetInstance();
    

  171.         AddDpptTask &addDpptTask = AddDpptTask::GetInstance();
    

  172.         AddNoUseTsTask &addNoUseTsTask = AddNoUseTsTask::GetInstance();
    

  173.         
    


  174. 

  175.         m_addTask->add(&addVideoTask);
    

  176.         m_addTask->add(&addDpptTask);
    

  177.         m_addTask->add(&addNoUseTsTask);
    

  178.         
    

  179. }
    


  180. 

  181. AppMessageAnalyzer::~AppMessageAnalyzer()
    

  182. {
    


  183. 

  184. }
    


  185. 

  186. AppMessageAnalyzer& AppMessageAnalyzer::GetInstance()
    

  187. {
    

  188.         static  AppMessageAnalyzer instance_;
    

  189.         return instance_; 
    

  190. }
    


  191. 

  192. void AppMessageAnalyzer::OnNewFrame(AppServerSession *appServerSion,string frame)
    

  193. {
    

  194.         Json::Value  value;  
    

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


  196. 

  197.         if(appServerSion == NULL){
    


  198. 

  199.                 return;
    

  200.         }
    


  201. 

  202.         std::auto_ptr<Json::Reader> pJsonParser(new Json::Reader(Json::Features::strictMode())); 
    


  203. 

  204.         if(pJsonParser->parse(frame,value)){
    

  205.                 if((!value["command"].isNull()) &&  (value["command"].isString())){
    

  206.                         m_addTask->AddSpacificTask(value,appServerSion);
    

  207.                 }
    

  208.         }
    

  209.         
    

  210. }
    


  211. 


  212. 


  213.
回复 赏

收藏2 举报

 楼主| keer_zu 发表于 2016-6-8 11:41 | 显示全部楼层
Task.h



复制
  1. #ifndef __TASK_H__
    

  2. #define __TASK_H__
    

  3. #include <string>
    

  4. #include <list>
    

  5. #include "json/json.h"
    

  6. #include <vector>
    

  7. //#include "CommandDb.h"
    


  8. 


  9. 

  10. using namespace std;
    


  11. 

  12. class Command;
    

  13. class TransServer;
    

  14. class Disptacher;
    

  15. class TsSession;
    


  16. 

  17. typedef enum
    

  18. {
    

  19.         TASK_HEAVY = 0,
    

  20.         TASK_LIGHT = 1
    

  21. }TaskProperty;
    


  22. 


  23. 


  24. 

  25. typedef struct 
    

  26. {
    


  27. 

  28. }ErrorInfo;
    


  29. 


  30. 

  31. class Task 
    

  32. {
    

  33. private:
    


  34. 

  35. protected:
    

  36.         string m_taskId;
    

  37.         bool m_isUseTs;
    

  38.         unsigned int m_taskPriority;
    

  39.         
    

  40.         Json::Value m_cmdValue;
    

  41.         
    

  42.         Command* m_command;
    

  43.         TransServer* m_transServer;
    

  44.         Disptacher* m_disptacher;
    


  45. 

  46.         int m_progress;
    

  47.         
    

  48. public:
    

  49.         vector<int> m_alreadyTriedTsType;
    

  50.         vector<string> m_alreadyTriedTsId;
    


  51. 

  52.         int m_triedTimes;
    

  53.         string m_appTargetIp;
    

  54.         unsigned int m_appTargetPort;
    


  55. 

  56.         int m_maxTryTimes;
    

  57.         TsSession* m_tsSession;
    

  58. public:
    

  59.         virtual ~Task(){}
    

  60.         Task()
    

  61.         {
    

  62.                 m_command = NULL;
    

  63.                 m_transServer = NULL;
    

  64.         }
    


  65. 

  66.         void Init()
    

  67.         {
    

  68.                 m_triedTimes = 0;
    

  69.         }
    


  70. 

  71.         void Release()
    

  72.         {
    

  73.                 m_alreadyTriedTsType.clear();
    

  74.                 vector<int>(m_alreadyTriedTsType).swap(m_alreadyTriedTsType);
    


  75. 

  76.                 m_alreadyTriedTsId.clear();
    

  77.                 vector<string>(m_alreadyTriedTsId).swap(m_alreadyTriedTsId);
    

  78.         }
    

  79.         
    

  80.         unsigned int GetPriority()
    

  81.         {
    

  82.                 return m_taskPriority;
    

  83.         }
    


  84. 

  85.         void SetDisptacher(Disptacher* disp)
    

  86.         {
    

  87.                 m_disptacher = disp;
    

  88.         }
    


  89. 

  90.         void SetProgress(int progress)
    

  91.         {
    

  92.                 m_progress = progress;
    

  93.         }
    


  94. 

  95.         int GetProgress()
    

  96.         {
    

  97.                 return m_progress;
    

  98.         }
    


  99. 

  100.         void SetPriority(unsigned int priority)
    

  101.         {
    

  102.                 m_taskPriority = priority;
    

  103.         }
    


  104. 

  105.         string GetTaskId()
    

  106.         {
    

  107.                 return m_taskId;
    

  108.         }
    


  109. 

  110.         void SetTaskId(string id)
    

  111.         {
    

  112.                 m_taskId = id;
    

  113.         }
    


  114. 

  115.         void SetCmdValue(Json::Value& value)
    

  116.         {
    

  117.                 m_cmdValue = value;
    

  118.         }
    


  119. 

  120.         Json::Value& GetCmdValue()
    

  121.         {
    

  122.                 return m_cmdValue;
    

  123.         }
    


  124. 

  125.         Command* GetCommand()
    

  126.         {
    

  127.                 return m_command;
    

  128.         }
    


  129. 

  130.         void SetCommand(Command* cmd)
    

  131.         {
    

  132.                 m_command = cmd;
    

  133.         }
    


  134. 

  135.         bool IsExceedMaxTryTimes()
    

  136.         {
    

  137.                 return (this->m_triedTimes >= this->m_maxTryTimes);
    

  138.         }
    


  139. 

  140.         void ResultReport(Json::Value& value);
    

  141. };
    


  142. 

  143. class TaskDocument : public Task
    

  144. {
    

  145. public:
    

  146.         TaskDocument();
    

  147.         TaskDocument(string taskId,unsigned int priority){m_taskId = taskId;m_taskPriority = priority;}
    


  148. 

  149.         void SetIsSpecific(bool is){m_isSpecificTsType = is;}
    

  150.         bool GetIsSpecific(){return m_isSpecificTsType;}
    

  151. private:
    

  152.         bool m_isSpecificTsType;
    

  153. };
    


  154. 

  155. class TaskVideo : public Task
    

  156. {
    

  157. public:
    

  158.         TaskVideo();
    

  159.         TaskVideo(string taskId,unsigned int priority){m_taskId = taskId;m_taskPriority = priority;}
    

  160. };
    


  161. 

  162. class TaskDppt : public Task
    

  163. {
    

  164. public:
    

  165.         TaskDppt();
    

  166.         TaskDppt(string taskId,unsigned int priority){m_taskId = taskId;m_taskPriority = priority;}
    

  167. };
    


  168. 

  169. class TaskNoUseTs : public Task
    

  170. {
    

  171. public:
    

  172.         TaskNoUseTs(){}
    

  173.         TaskNoUseTs(string taskId,unsigned int priority){m_taskId = taskId;m_taskPriority = priority;}
    

  174. };
    


  175. 


  176. 


  177. 

  178. class TaskCmp
    

  179. {
    

  180. public:
    

  181.         bool operator()(Task* a,Task* b)
    

  182.         {
    

  183.                 if(a->GetPriority() < b->GetPriority())
    

  184.                         return true;
    

  185.                 else if(a->GetPriority() == b->GetPriority())
    

  186.                         return a > b;
    

  187.                 else
    

  188.                         return false;
    

  189.         }
    


  190. 

  191. };
    


  192. 

  193. class TaskDb
    

  194. {
    

  195. public:
    

  196.         virtual Task* GetTask() = 0;
    


  197. 

  198.         void GiveBackTask(Task *task)
    

  199.         {
    

  200.                 task->Release();
    

  201.                 m_taskBuf.push_back(task);
    

  202.         }
    

  203. protected:
    

  204.         list<Task*> m_taskBuf;
    

  205. };
    


  206. 

  207. class TaskVideoDb : public TaskDb
    

  208. {
    

  209. public:
    

  210.         virtual Task* GetTask()
    

  211.         {
    

  212.                 if(!m_taskBuf.empty())
    

  213.                         return m_taskBuf.front();
    

  214.                 else
    

  215.                         return new TaskVideo;
    

  216.         }
    

  217. };
    


  218. 

  219. class TaskDocumentDb : public TaskDb
    

  220. {
    

  221. public:
    

  222.         virtual Task* GetTask()
    

  223.         {
    

  224.                 if(!m_taskBuf.empty())
    

  225.                         return m_taskBuf.front();
    

  226.                 else
    

  227.                         return new TaskDocument;
    

  228.         }
    

  229. };
    


  230. 

  231. class TaskDpptDb : public TaskDb
    

  232. {
    

  233. public:
    

  234.         virtual Task* GetTask()
    

  235.         {
    

  236.                 if(!m_taskBuf.empty())
    

  237.                         return m_taskBuf.front();
    

  238.                 else
    

  239.                         return new TaskDppt;
    

  240.         }
    

  241. };
    


  242. 


  243. 

  244. class TaskNoUseTsDb : public TaskDb
    

  245. {
    

  246. public:
    

  247.         virtual Task* GetTask()
    

  248.         {
    

  249.                 if(!m_taskBuf.empty())
    

  250.                         return m_taskBuf.front();
    

  251.                 else
    

  252.                         return new TaskNoUseTs;
    

  253.         }
    

  254. };
    


  255. 


  256. 


  257. 

  258. #endif
    


  259.
回复 赏

收藏2 举报

 楼主| keer_zu 发表于 2016-6-8 11:42 | 显示全部楼层
Task.cpp


复制
  1. #include "Task.h"
    

  2. #include "CommandDb.h"
    

  3. /////////////////////////// Task /////////////////////////////
    

  4. void Task::ResultReport(Json::Value& value)
    

  5. {
    

  6.         Json::Value appResult;
    

  7.         string result;
    

  8.         Command* cmd;
    

  9.         bool ret;
    

  10.         
    


  11. 


  12. 

  13.         cmd = this->GetCommand();
    

  14.         
    

  15.         ret = cmd->BuildAppResult(value,appResult);
    

  16.         if(ret){
    

  17.                 result = appResult.toStyledString();
    

  18.                 SessionManager::GetInstance().SendAppMessage(this->m_appTargetIp,this->m_appTargetPort,result,this);
    

  19.         } else {
    


  20. 

  21.         }
    


  22. 


  23. 

  24. }
    


  25. 


  26. 

  27. ///////////////////////// TaskDocument ///////////////////////
    

  28. TaskDocument::TaskDocument()
    

  29. {
    

  30.         m_maxTryTimes = 3;
    

  31. }
    


  32. 


  33. 

  34. ///////////////////////// TaskVideo ///////////////////////
    

  35. TaskVideo::TaskVideo()
    

  36. {
    

  37.         m_maxTryTimes = 3;
    

  38. }
    


  39. 


  40. 


  41. 

  42. ///////////////////////// TaskDppt ///////////////////////
    

  43. TaskDppt::TaskDppt()
    

  44. {
    

  45.         m_maxTryTimes = 3;
    

  46. }
回复 赏

收藏2 举报

 楼主| keer_zu 发表于 2016-6-8 11:44 | 显示全部楼层
TaskQueue.h


复制
  1. #ifndef __TASK_QUEUE_H__
    

  2. #define __TASK_QUEUE_H__
    

  3. #include <queue>  
    

  4. #include <list>
    

  5. #include "Task.h"
    


  6. 

  7. typedef priority_queue<Task*,vector<Task*>,TaskCmp> TaskPriorityQueue;
    


  8. 


  9. 


  10. 

  11. class TaskWaitQueue
    

  12. {
    

  13. public:
    

  14.         Task* PopTask();
    


  15. 

  16.         Task* GetTaskInSpecId(string taskId);
    

  17.         
    

  18.         bool PushTask(Task *task);
    


  19. 

  20.         bool CheckSameTaskId(string TaskId);
    

  21. private:
    

  22.         TaskPriorityQueue m_queue;
    

  23. };
    


  24. 


  25. 

  26. class TaskRunQueue
    

  27. {
    

  28. public:
    

  29.         bool PushTask(Task *task,TsSession *session);
    

  30.         Task* GetTaskInSpecId(string taskId);
    

  31.         Task* GetTaskInSession(TsSession* session);
    

  32.         bool DelTask(string taskId);
    

  33.         bool CheckSameTaskId(string TaskId);
    

  34. private:
    

  35.         list<Task *> m_taskList;
    

  36. };
    


  37. 


  38. 


  39. 

  40. #endif
回复 赏

收藏2 举报

 楼主| keer_zu 发表于 2016-6-8 11:44 | 显示全部楼层
TaskQueue.cpp



复制
  1. #include "TaskQueue.h"
    

  2. #include <vector>
    

  3. #include <iostream>
    


  4. 

  5. using namespace std;
    


  6. 

  7. TaskWaitQueue GDocTaskWaitQueue;
    

  8. TaskWaitQueue GVideoTaskWaitQueue;
    

  9. TaskWaitQueue GDpptTaskWaitQueue;
    

  10. TaskWaitQueue GNoTsTaskTaskWaitQueue;
    


  11. 


  12. 

  13. TaskRunQueue GDocTaskRunQueue;
    

  14. TaskRunQueue GVideoTaskRunQueue;
    

  15. TaskRunQueue GDpptTaskRunQueue;
    

  16. TaskRunQueue GNoTsTaskRunQueue;
    


  17. 

  18. TaskDocumentDb GTaskDocumentDb;
    

  19. TaskVideoDb GTaskVideoDb;
    

  20. TaskDpptDb GTaskDpptDb;
    

  21. TaskNoUseTsDb GTaskNoUseTsDb;
    


  22. 


  23. 

  24. Task* TaskWaitQueue::PopTask()
    

  25. {
    

  26.         Task* task;
    

  27.         if(m_queue.empty())
    

  28.                 return NULL;
    


  29. 

  30.         task = m_queue.top( );
    

  31.         m_queue.pop();
    


  32. 

  33.         return task;
    

  34. }
    


  35. 

  36. Task* TaskWaitQueue::GetTaskInSpecId(string taskId)
    

  37. {
    

  38.         int i;
    

  39.         vector<Task *> *vtor = (vector<Task *> *)&m_queue;
    


  40. 

  41.         for( int i = 0 ; i < vtor->size(); i++ ){
    

  42.                 if(((Task *)(vtor->operator [](i)))->GetTaskId() == taskId)
    

  43.                         return (Task *)(vtor->operator [](i));
    

  44.         }
    


  45. 

  46.         return NULL;
    

  47. }
    


  48. 

  49. bool TaskWaitQueue::PushTask(Task* task)
    

  50. {
    

  51.         task->m_tsSession = NULL;
    

  52.          m_queue.push(task);
    


  53. 

  54.          return true;
    

  55. }
    


  56. 


  57. 

  58. bool TaskWaitQueue::CheckSameTaskId(string id)
    

  59. {
    

  60.         int i;
    

  61.         vector<Task *> *vtor = (vector<Task *> *)&m_queue;
    


  62. 

  63.         for( int i = 0 ; i < vtor->size(); i++ ){
    

  64.                 if(((Task *)(vtor->operator [](i)))->GetTaskId() == id)
    

  65.                         return true;
    

  66.         }
    

  67.         
    

  68.         return false;
    

  69. }
    

  70. ////////////////////////// TaskRunQueue //////////////////////////////////
    


  71. 

  72. bool TaskRunQueue::PushTask(Task* task,TsSession* session)
    

  73. {
    

  74.         task->m_tsSession = session;
    

  75.         m_taskList.push_back(task);
    


  76. 

  77.         return true;
    

  78. }
    


  79. 

  80. Task* TaskRunQueue::GetTaskInSpecId(string taskId)
    

  81. {
    

  82.         list<Task *>::iterator it;
    

  83.         
    

  84.         for(it = m_taskList.begin();it != m_taskList.end();it ++){
    

  85.                 if((*it)->GetTaskId() == taskId){
    

  86.                         return (Task *)(*it);
    

  87.                 }
    

  88.         }
    


  89. 

  90.         return NULL;
    

  91. }
    


  92. 

  93. Task* TaskRunQueue::GetTaskInSession(TsSession* session)
    

  94. {
    

  95.         list<Task *>::iterator it;
    

  96.         
    

  97.         for(it = m_taskList.begin();it != m_taskList.end();it ++){
    

  98.                 if((*it)->m_tsSession == session){
    

  99.                         return (Task *)(*it);
    

  100.                 }
    

  101.         }
    


  102. 

  103.         return NULL;
    

  104. }
    


  105. 

  106. bool TaskRunQueue::DelTask(string taskId)
    

  107. {
    

  108.         list<Task *>::iterator it;
    

  109.         bool ret = false;
    


  110. 

  111.         for(it = m_taskList.begin();it != m_taskList.end();it ++){
    

  112.                 if((*it)->GetTaskId() == taskId){
    

  113.                         (*it)->m_tsSession = NULL;
    

  114.                         m_taskList.erase(it);
    

  115.                         ret = true;
    

  116.                 }
    

  117.         }
    


  118. 

  119.         return ret;
    

  120. }
    


  121. 

  122. bool TaskRunQueue::CheckSameTaskId(string taskId)
    

  123. {
    

  124.         list<Task *>::iterator it;
    

  125.         bool ret = false;
    


  126. 

  127.         for(it = m_taskList.begin();it != m_taskList.end();it ++){
    

  128.                 if((*it)->GetTaskId() == taskId){
    

  129.                         ret = true;
    

  130.                 }
    

  131.         }
    


  132. 

  133.         return ret;
    

  134. }
    


  135. 


  136. 


  137.
回复 赏

收藏2 举报

 楼主| keer_zu 发表于 2016-6-8 11:48 | 显示全部楼层
TaskResult.h



复制
  1. #ifndef __TASK_RESULT_H__
    

  2. #define __TASK_RESULT_H__
    


  3. 

  4. #include <iostream>
    

  5. #include <string>
    

  6. #include <vector>
    

  7. #include "TsInterface.h"
    

  8. #include "json/json.h"
    

  9. #include "InterfaceApi.h"
    

  10. #include "Disptacher.h"
    

  11. #include "Log4cxxWrapper.h"
    

  12. //#include "CommandDb.h"
    


  13. 

  14. class CommandDb;
    


  15. 


  16. 


  17. 


  18. 

  19. class TaskResult// : public ITaskResult
    

  20. {
    

  21.         TaskResult *next; // 1. "next" pointer in the base class
    

  22.         
    

  23. protected:
    

  24.         vector<string> m_resultNames;
    

  25.         TaskDb *m_taskDb;
    

  26.         Disptacher *m_disptacher;
    

  27.         CommandDb* m_commandDb;
    

  28.         TaskRunQueue* m_taskRunQueue;
    


  29. 

  30. public:
    

  31.         TaskResult();
    

  32.         
    

  33.         bool IsThisTaskType(const string resultName)
    

  34.         {
    

  35.                 vector<string>::iterator it;
    

  36.                 
    

  37.                 for (it = m_resultNames.begin(); it != m_resultNames.end(); ++ it){
    

  38.                         if(resultName == *it)
    

  39.                                 return true;
    

  40.                 }
    


  41. 

  42.                 return false;
    

  43.         }
    


  44. 


  45. 

  46.         
    

  47.                 
    

  48.         void setNext(TaskResult *n)
    

  49.         {
    

  50.                 next = n;
    

  51.         }
    

  52.         void add(TaskResult *n)
    

  53.         {
    

  54.                 if (next)
    

  55.                         next->add(n);
    

  56.                 else
    

  57.                         next = n;
    

  58.         }
    

  59.         virtual void SpacificTaskResult(Json::Value& value,TsSession* tsServerSion)
    

  60.         {
    

  61.                 if(next != NULL)
    

  62.                         next->SpacificTaskResult(value,tsServerSion);
    

  63.                 else {   // this command does not exist;
    

  64.                         printf("error");
    

  65.                         // TODO: log
    

  66.                 }
    

  67.         }
    


  68. 

  69.         void DoTaskRresult(Json::Value& value,TsSession* session)
    

  70.         {
    

  71.                 Task* task;
    

  72.                 string errorcode;
    

  73.                 
    

  74.                 task = m_taskRunQueue->GetTaskInSession(session);
    

  75.                 if(!task){
    

  76.                         // TODO: log
    

  77.                         return;
    

  78.                 }
    

  79.                 
    

  80.                 errorcode = value["errorcode"].asString();
    

  81.                 if(atoi(errorcode.c_str()) != 0){
    

  82.                         if(task->IsExceedMaxTryTimes()){
    

  83.                                 // TODO: log
    

  84.                                 task->ResultReport(value);
    

  85.                                 m_taskRunQueue->DelTask(task->GetTaskId());
    

  86.                                 m_taskDb->GiveBackTask(task);
    

  87.                         } else {
    

  88.                                 m_disptacher->Submit(task);
    

  89.                         }
    


  90. 

  91.                         return;
    

  92.                 }
    

  93.                 
    

  94.                 task->ResultReport(value);
    

  95.                 m_taskRunQueue->DelTask(task->GetTaskId());
    

  96.                 m_taskDb->GiveBackTask(task);
    


  97. 

  98.                 return;
    

  99.         }
    


  100. 

  101. };
    


  102. 

  103. class VideoTaskResult : public TaskResult
    

  104. {
    

  105.         VideoTaskResult();
    

  106. public:
    


  107. 

  108.         static VideoTaskResult& GetInstance();
    

  109.         virtual void SpacificTaskResult(Json::Value& value,TsSession* tsServerSion);        
    

  110. };
    


  111. 

  112. class DocTaskResult : public TaskResult
    

  113. {
    

  114.         DocTaskResult();
    

  115. public:
    


  116. 

  117.         static DocTaskResult& GetInstance();
    

  118.         virtual void SpacificTaskResult(Json::Value& value,TsSession* tsServerSion);
    

  119. };
    


  120. 

  121. class DpptTaskResult : public TaskResult
    

  122. {
    

  123.         DpptTaskResult();
    

  124. public:
    


  125. 

  126.         static DpptTaskResult& GetInstance();
    

  127.         virtual void SpacificTaskResult(Json::Value& value,TsSession* tsServerSion);
    

  128. };
    


  129. 


  130. 


  131. 


  132. 

  133. #endif
    


  134.
回复 赏

收藏2 举报

 楼主| keer_zu 发表于 2016-6-8 11:49 | 显示全部楼层
TaskResult.cpp


复制
  1. #include "TaskResult.h"
    

  2. #include "CommandDb.h"
    


  3. 

  4. extern TaskVideoDb GTaskVideoDb;
    


  5. 

  6. extern TaskDocumentDb GTaskDocumentDb;
    

  7. extern TaskDpptDb GTaskDpptDb;
    


  8. 

  9. extern TaskRunQueue GDocTaskRunQueue;
    

  10. extern TaskRunQueue GVideoTaskRunQueue;
    

  11. extern TaskRunQueue GDpptTaskRunQueue;
    


  12. 

  13. ////////////////////////////////////// TaskResult /////////////////////////////////////////
    


  14. 

  15. TaskResult::TaskResult()
    

  16. {
    

  17.         next = NULL; 
    

  18.         m_commandDb = &CommandDb::GetInstance();
    

  19. }
    


  20. 


  21. 

  22. //////////////////////////////////// VideoTaskResult //////////////////////////////////////
    


  23. 


  24. 

  25. VideoTaskResult& VideoTaskResult::GetInstance()
    

  26. {
    

  27.         static  VideoTaskResult instance_;
    

  28.         return instance_;         
    

  29. }
    


  30. 


  31. 

  32. VideoTaskResult::VideoTaskResult()
    

  33. {
    

  34.         m_commandDb->GetResultNameInSpecificTaskType(VideoTask,m_resultNames);
    

  35.         
    

  36.         m_taskDb = &GTaskVideoDb;
    

  37.         m_disptacher = &VideoDisptacher::GetInstance();
    

  38.         m_taskRunQueue = &GVideoTaskRunQueue;
    

  39. }
    


  40. 

  41. void VideoTaskResult::SpacificTaskResult(Json::Value& value,TsSession* session)
    

  42. {
    

  43.         if(IsThisTaskType(value["servertype"].asString())) {
    

  44.                 
    

  45.                 cout << "---  video result!" << endl;
    

  46.                 DoTaskRresult(value,session);
    

  47.         } else {
    

  48.                 TaskResult::SpacificTaskResult(value,session);
    

  49.         }
    

  50. }
    


  51. 


  52. 

  53. //////////////////////////////////// DocTaskResult //////////////////////////////////////
    


  54. 


  55. 

  56. DocTaskResult& DocTaskResult::GetInstance()
    

  57. {
    

  58.         static  DocTaskResult instance_;
    

  59.         return instance_;         
    

  60. }
    


  61. 


  62. 

  63. DocTaskResult::DocTaskResult()
    

  64. {
    

  65.         m_commandDb->GetResultNameInSpecificTaskType(DocTask,m_resultNames);
    

  66.         
    

  67.         m_taskDb = &GTaskDocumentDb;
    

  68.         m_disptacher = &DocDisptacher::GetInstance();//GDocDisptacher;
    

  69.         m_taskRunQueue = &GDocTaskRunQueue;
    

  70. }
    


  71. 

  72. void DocTaskResult::SpacificTaskResult(Json::Value& value,TsSession* session)
    

  73. {
    

  74.         Task* task;
    


  75. 

  76.         if(IsThisTaskType(value["servertype"].asString())) {
    

  77.                 
    

  78.                 cout << "---  Doc result!" << endl;
    

  79.                 DoTaskRresult(value,session);
    

  80.                 
    

  81.         } else {
    

  82.                 TaskResult::SpacificTaskResult(value,session);
    

  83.         }
    

  84. }
    


  85. 

  86. //////////////////////////////////// DpptTaskResult //////////////////////////////////////
    


  87. 


  88. 

  89. DpptTaskResult& DpptTaskResult::GetInstance()
    

  90. {
    

  91.         static  DpptTaskResult instance_;
    

  92.         return instance_;         
    

  93. }
    


  94. 


  95. 

  96. DpptTaskResult::DpptTaskResult()
    

  97. {
    

  98.         m_commandDb->GetResultNameInSpecificTaskType(DpptTask,m_resultNames);
    

  99.         
    

  100.         m_taskDb = &GTaskDpptDb;
    

  101.         m_disptacher = &DpptDisptacher::GetInstance();//&GDpptDisptacher;
    

  102.         m_taskRunQueue = &GDpptTaskRunQueue;
    

  103. }
    


  104. 

  105. void DpptTaskResult::SpacificTaskResult(Json::Value& value,TsSession* session)
    

  106. {
    

  107.         Task* task;
    


  108. 

  109.         if(IsThisTaskType(value["servertype"].asString())) {
    

  110.                 
    

  111.                 cout << "---  Dppt result!" << endl;
    

  112.                 DoTaskRresult(value,session);
    

  113.                 
    

  114.         } else {
    

  115.                 TaskResult::SpacificTaskResult(value,session);
    

  116.         }
    

  117. }
回复 赏

收藏2 举报

 楼主| keer_zu 发表于 2016-6-8 11:51 | 显示全部楼层
TransServer.h



复制
  1. #ifndef __TRANS_SERVER_H__
    

  2. #define __TRANS_SERVER_H__
    

  3. #include <string>
    

  4. #include <list>
    

  5. #include "Task.h"
    

  6. using namespace std;
    


  7. 

  8. class TsSession;
    


  9. 

  10. typedef enum{
    

  11.         TsIdle = 0,
    

  12.         TsRunning
    

  13. }TsState;
    


  14. 

  15. typedef enum{
    

  16.         DocTrans = 0,
    

  17.         VideoTrans,
    

  18.         DpptTrans
    

  19. }ServerType;
    


  20. 

  21. typedef enum{
    

  22.         OpenofficeDocTrans = 0,
    

  23.         WpsDocTrans,
    

  24.         OfficeDocTrans
    

  25. }DocTransType;
    


  26. 


  27. 

  28. class TransServer
    

  29. {
    

  30. public:
    

  31.         virtual ~TransServer(){}
    

  32.         TransServer(){m_tsState = TsIdle;}
    

  33.         string GetId()
    

  34.         {
    

  35.                 return m_tsId;
    

  36.         }
    


  37. 

  38.         void SetId(string& id)
    

  39.         {
    

  40.                 m_tsId = id;
    

  41.         }
    


  42. 

  43.         ServerType GetServerType()
    

  44.         {
    

  45.                 return m_serverType;
    

  46.         }
    


  47. 

  48.         TsState GetState()
    

  49.         {
    

  50.                 return m_tsState;
    

  51.         }
    


  52. 

  53.         void SetState(TsState state)
    

  54.         {
    

  55.                 m_tsState = state;
    

  56.         }
    


  57. 

  58.         void SetSession(TsSession* session)
    

  59.         {
    

  60.                 m_session = session;
    

  61.         }
    


  62. 

  63.         TsSession* GetSession()
    

  64.         {
    

  65.                 return m_session;
    

  66.         }
    


  67. 

  68.         void Release()
    

  69.         {
    

  70.                 m_task = NULL;
    

  71.                 m_session = NULL;
    

  72.         }
    


  73. 

  74.         void SetTask(Task* task)
    

  75.         {
    

  76.                 m_task = task;
    

  77.         }
    


  78. 

  79.         Task* GetTask()
    

  80.         {
    

  81.                 return m_task;
    

  82.         }
    

  83. private:
    

  84.         string m_tsId;
    

  85.         
    

  86. protected:
    

  87.         TsSession* m_session;
    

  88.         ServerType m_serverType;
    

  89.         TsState m_tsState;
    

  90.         Task* m_task;
    

  91. };
    


  92. 

  93. class DocTransServer : public TransServer
    

  94. {
    


  95. 

  96. public:
    

  97.         DocTransServer(){}
    

  98.         DocTransServer(string& id,DocTransType type)
    

  99.         {
    

  100.                 SetId(id);
    

  101.                 m_serverType = DocTrans;
    

  102.                 m_docTransType = type;
    

  103.         }
    

  104. private:
    

  105.         DocTransType m_docTransType;
    

  106. };
    


  107. 


  108. 

  109. class VideoTransServer : public TransServer
    

  110. {
    

  111. public:
    

  112.         VideoTransServer(){}
    

  113.         VideoTransServer(string& id)
    

  114.         {
    

  115.                 SetId(id);
    

  116.                 m_serverType = VideoTrans;
    

  117.         }
    

  118. };
    


  119. 

  120. class DpptTransServer : public TransServer
    

  121. {
    

  122. public:
    

  123.         DpptTransServer(){}
    

  124.         DpptTransServer(string& id)
    

  125.         {
    

  126.                 SetId(id);
    

  127.                 m_serverType = DpptTrans;
    

  128.         }
    

  129. };
    


  130. 


  131. 

  132. class TransServerDb
    

  133. {
    

  134. public:
    

  135.         virtual TransServer* GetTransServer() = 0;
    


  136. 

  137.         void GiveBackTransServer(TransServer *ts)
    

  138.         {
    

  139.                 ts->Release();
    

  140.                 m_transServerBuf.push_back(ts);
    

  141.         }
    

  142. protected:
    

  143.         list<TransServer*> m_transServerBuf;
    

  144. };
    


  145. 

  146. class DocTransServerDb : public TransServerDb
    

  147. {
    

  148.         DocTransServerDb(){}
    

  149. public:
    

  150.         static DocTransServerDb& GetInstance()
    

  151.         {
    

  152.                 static DocTransServerDb instance_;
    

  153.                 return instance_;
    

  154.         }
    

  155.         virtual TransServer* GetTransServer()
    

  156.         {
    

  157.                 if(!m_transServerBuf.empty())
    

  158.                         return m_transServerBuf.front();
    

  159.                 else
    

  160.                         return new DocTransServer;                
    

  161.         }
    

  162. };
    


  163. 

  164. class VideoTransServerDb : public TransServerDb
    

  165. {
    

  166.         VideoTransServerDb(){}
    

  167. public:
    

  168.         static VideoTransServerDb& GetInstance()
    

  169.         {
    

  170.                 static VideoTransServerDb instance_;
    

  171.                 return instance_;
    

  172.         }
    

  173.         virtual TransServer* GetTransServer()
    

  174.         {
    

  175.                 if(!m_transServerBuf.empty())
    

  176.                         return m_transServerBuf.front();
    

  177.                 else
    

  178.                         return new VideoTransServer;                
    

  179.         }
    

  180. };
    


  181. 

  182. class DpptTransServerDb : public TransServerDb
    

  183. {
    

  184.         DpptTransServerDb(){}
    

  185. public:
    

  186.         static DpptTransServerDb& GetInstance()
    

  187.         {
    

  188.                 static DpptTransServerDb instance_;
    

  189.                 return instance_;
    

  190.         }
    

  191.         virtual TransServer* GetTransServer()
    

  192.         {
    

  193.                 if(!m_transServerBuf.empty())
    

  194.                         return m_transServerBuf.front();
    

  195.                 else
    

  196.                         return new DpptTransServer;                
    

  197.         }
    

  198. };
    


  199. 

  200. #endif
回复 赏

收藏2 举报

 楼主| keer_zu 发表于 2016-6-8 11:51 | 显示全部楼层
TransServer.cpp



复制
  1. #include "TransServer.h"
    


  2. 


  3.
回复 赏

收藏2 举报

 楼主| keer_zu 发表于 2016-6-8 11:53 | 显示全部楼层
TsManager.h


复制
  1. #ifndef __TS_MANAGER_H__
    

  2. #define __TS_MANAGER_H__
    


  3. 

  4. #include "Message.h"
    

  5. #include "TsInterface.h"
    


  6. 

  7. typedef enum
    

  8. {
    


  9. 

  10.         TS_DOCUMENT_LINUX = 0,
    


  11. 

  12.         TS_DOCUMENT_OFFICE = 1,
    


  13. 

  14.         TS_DOCUMENT_WPS = 2,
    


  15. 

  16.         TS_VIDEO = 3,
    


  17. 

  18.         TS_DYNAMIC_PPT =4
    


  19. 

  20. } TsType;
    


  21. 


  22. 

  23. typedef enum
    

  24. {
    

  25.         TS_HEAVY = 0,
    

  26.         TS_LIGHT = 1
    

  27. }TsProperty;
    


  28. 

  29. class AddTransServer;
    


  30. 

  31. class TsRegister : public ITsRegister
    

  32. {
    

  33.         AddTransServer *m_addTransServer;
    

  34. public:
    

  35.         TsRegister();
    

  36.         virtual void OnRegister(Json::Value& value,TsSession *session);
    

  37. };
    


  38. 

  39. class AddTransServer
    

  40. {
    

  41.         AddTransServer *next;
    

  42. protected:
    

  43.         TsQueue *m_tsQueue;
    

  44.         string m_serverType;
    


  45. 

  46. public:
    

  47.         AddTransServer();
    

  48.         void AddTsTransaction(Json::Value& value,TsSession*);
    

  49.         void setNext(AddTransServer *n)
    

  50.         {
    

  51.                 next = n;
    

  52.         }
    

  53.         void add(AddTransServer *n)
    

  54.         {
    

  55.                 if (next)
    

  56.                         next->add(n);
    

  57.                 else
    

  58.                         next = n;
    

  59.         }
    

  60.         virtual void AddSpacificTransServer(Json::Value& value,TsSession*session)
    

  61.         {
    

  62.                 if(next != NULL)
    

  63.                         next->AddSpacificTransServer(value,session);
    

  64.                 else {   // this command does not exist;
    

  65.                         printf("error");
    

  66.                         // TODO: log
    

  67.                 }
    

  68.         }
    


  69. 

  70. };
    


  71. 

  72. class AddDocTransServer : public AddTransServer
    

  73. {
    

  74. public:
    

  75.         AddDocTransServer();
    

  76.         //static AddDocTransServer& GetInstance();
    

  77.         virtual void AddSpacificTransServer(Json::Value& value,TsSession*TsSession);
    

  78. };
    


  79. 

  80. class AddOpenofficeTransServer : public AddDocTransServer
    

  81. {
    

  82.         AddOpenofficeTransServer();
    

  83. public:
    

  84.         static AddOpenofficeTransServer& GetInstance();
    

  85.         virtual void AddSpacificTransServer(Json::Value& value,TsSession*TsSession);
    

  86. };
    


  87. 


  88. 

  89. class AddWpsTransServer : public AddDocTransServer
    

  90. {
    

  91.         AddWpsTransServer();
    

  92. public:
    

  93.         static AddWpsTransServer& GetInstance();
    

  94.         virtual void AddSpacificTransServer(Json::Value& value,TsSession*TsSession);
    

  95. };
    


  96. 

  97. class AddOfficeTransServer : public AddDocTransServer
    

  98. {
    

  99.         AddOfficeTransServer();
    

  100. public:
    

  101.         static AddOfficeTransServer& GetInstance();
    

  102.         virtual void AddSpacificTransServer(Json::Value& value,TsSession*TsSession);
    

  103. };
    


  104. 


  105. 

  106. class AddVideoTransServer : public AddTransServer
    

  107. {
    

  108.         AddVideoTransServer();
    

  109. public:
    

  110.         static AddVideoTransServer& GetInstance();
    

  111.         virtual void AddSpacificTransServer(Json::Value& value,TsSession*TsSession);
    

  112. };
    


  113. 


  114. 

  115. class AddDpptTransServer : public AddTransServer
    

  116. {
    

  117.         AddDpptTransServer();
    

  118. public:
    

  119.         static AddDpptTransServer& GetInstance();
    

  120.         virtual void AddSpacificTransServer(Json::Value& value,TsSession*TsSession);
    

  121. };
    


  122. 

  123. class TsLeaveHandler;
    


  124. 

  125. class TransServerLeave : public ITsServerLeave
    

  126. {
    

  127.         TransServerLeave();
    

  128.         TsLeaveHandler* m_tsLeaveHandler;
    

  129. public:
    

  130.         static TransServerLeave& GetInstance();
    

  131.         virtual void OnServerLeave(TsSession &session);
    

  132. };
    


  133. 

  134. class TsLeaveHandler
    

  135. {
    

  136.         TsLeaveHandler* next;
    

  137. protected:
    

  138.         TsQueue* m_tsQueue;
    

  139.         TransServerDb* m_tsDb;
    

  140.         Disptacher* m_disptacher;
    

  141. public:
    

  142.         TransServer* FindSession(TsSession* session);
    

  143.         void setNext(TsLeaveHandler *n)
    

  144.         {
    

  145.                 next = n;
    

  146.         }
    

  147.         void add(TsLeaveHandler *n)
    

  148.         {
    

  149.                 if (next)
    

  150.                         next->add(n);
    

  151.                 else
    

  152.                         next = n;
    

  153.         }
    

  154.         virtual void SpacificTsLeave(TsSession* TsSession)
    

  155.         {
    

  156.                 if(next != NULL)
    

  157.                         next->SpacificTsLeave(TsSession);
    

  158.                 else {   // this command does not exist;
    

  159.                         printf("error");
    

  160.                         // TODO: log
    

  161.                 }
    

  162.         }
    


  163. 

  164.         void ProcessTsAndTask(TransServer *ts)
    

  165.         {
    

  166.                 Task* task;
    

  167.                 
    

  168.                 m_tsQueue->DelTs(ts);
    

  169.                 ts->SetState(TsIdle);
    

  170.                 ts->SetSession(NULL);
    

  171.                 ts->Release();
    


  172. 

  173.                 m_tsDb->GiveBackTransServer(ts);
    


  174. 

  175.                 task = ts->GetTask();
    

  176.                 m_disptacher->Submit(task);
    

  177.         }
    


  178. 

  179. };
    


  180. 

  181. class TsDocLeaveHandler : public TsLeaveHandler
    

  182. {
    

  183. public:
    

  184.         TsDocLeaveHandler()
    

  185.         {
    


  186. 

  187.         }
    

  188. };
    


  189. 

  190. class TsOpenofficeLeaveHandler : public TsDocLeaveHandler
    

  191. {
    

  192.         TsOpenofficeLeaveHandler();
    

  193. public:
    

  194.         static TsOpenofficeLeaveHandler& GetInstance();
    


  195. 

  196.         virtual void SpacificTsLeave(TsSession* session);
    

  197. };
    


  198. 

  199. class TsWpsLeaveHandler : public TsDocLeaveHandler
    

  200. {
    

  201.         TsWpsLeaveHandler();
    

  202. public:
    

  203.         static TsWpsLeaveHandler& GetInstance();
    


  204. 

  205.         virtual void SpacificTsLeave(TsSession* session);
    

  206. };
    


  207. 

  208. class TsOfficeLeaveHandler : public TsDocLeaveHandler
    

  209. {
    

  210.         TsOfficeLeaveHandler();
    

  211. public:
    

  212.         static TsOfficeLeaveHandler& GetInstance();
    


  213. 

  214.         virtual void SpacificTsLeave(TsSession* session);
    

  215. };
    


  216. 


  217. 

  218. class TsVideoLeaveHandler : public TsLeaveHandler
    

  219. {
    

  220.         TsVideoLeaveHandler();
    

  221. public:
    

  222.         static TsVideoLeaveHandler& GetInstance();
    


  223. 

  224.         virtual void SpacificTsLeave(TsSession* session);
    

  225. };
    


  226. 


  227. 


  228. 

  229. class TsDpptLeaveHandler : public TsLeaveHandler
    

  230. {
    

  231.         TsDpptLeaveHandler();
    

  232. public:
    

  233.         static TsDpptLeaveHandler& GetInstance();
    


  234. 

  235.         virtual void SpacificTsLeave(TsSession* session);
    

  236. };
    


  237. 


  238. 

  239. #endif
    


  240.
回复 赏

收藏2 举报

 楼主| keer_zu 发表于 2016-6-8 11:53 | 显示全部楼层
TsManager.cpp


复制
  1. #include "TsManager.h"
    


  2. 


  3. 

  4. extern  TsQueue GVideoTsQueue;
    

  5. extern  TsQueue GDocOpenofficeTsQueue;
    

  6. extern  TsQueue GDocWpsTsQueue;
    

  7. extern  TsQueue GDocOfficeTsQueue;
    

  8. extern  TsQueue GDpptTsQueue;
    

  9. /////////////////////// TsRegister ////////////////////
    


  10. 

  11. TsRegister::TsRegister()
    

  12. {
    

  13.         m_addTransServer = &AddOpenofficeTransServer::GetInstance();
    

  14.         m_addTransServer->add(&AddWpsTransServer::GetInstance());
    

  15.         m_addTransServer->add(&AddOfficeTransServer::GetInstance());
    

  16.         m_addTransServer->add(&AddVideoTransServer::GetInstance());
    

  17.         m_addTransServer->add(&AddDpptTransServer::GetInstance());
    

  18. }
    


  19. 

  20. void TsRegister::OnRegister(Json::Value& value,TsSession *session)
    

  21. {
    

  22.         m_addTransServer->AddSpacificTransServer(value,session);
    

  23. }
    


  24. 

  25. ////////////////////// AddTransServer /////////////////////
    

  26. AddTransServer::AddTransServer()
    

  27. {
    


  28. 

  29. }
    

  30. void AddTransServer::AddTsTransaction(Json::Value & value, TsSession* session)
    

  31. {
    

  32.         TsRegistMessage* regMessage;
    

  33.         TsMessage* message;
    

  34.         int errorCode;
    

  35.         string errorDetail;
    

  36.         string msg;
    

  37.         
    

  38.         message = TsMessageDb::GetInstance().GetMessage(TsRegistMsg,m_serverType);
    

  39.         if(!message){
    

  40.                 // TODO:log
    

  41.                 return;
    

  42.         }
    

  43.         
    

  44.         if(regMessage = dynamic_cast<TsRegistMessage *>(message)){
    

  45.                 
    

  46.         } else {
    

  47.                 // TODO:log
    

  48.                 return;
    

  49.         }
    

  50.         
    

  51.         
    

  52.         if(m_tsQueue->CheckSameTs(value["id"].asString())){
    

  53.                 errorCode = 1;  // TODO:
    

  54.                 errorDetail = "Repeat ts id!";
    

  55.                 regMessage->BuildResponse(errorCode,errorDetail,msg);
    

  56.                 session->SendMessage(msg);
    

  57.         } else {
    


  58. 

  59.                 TransServer* ts = VideoTransServerDb::GetInstance().GetTransServer();
    

  60.                 m_tsQueue->PushTs(ts);
    

  61.                 errorCode = 0;
    

  62.                 errorDetail = "";
    

  63.                 regMessage->BuildResponse(errorCode,errorDetail,msg);
    

  64.                 session->SendMessage(msg);
    

  65.                 
    

  66.         }
    


  67. 

  68. }
    


  69. 

  70. ///////////////////// AddDocTransServer //////////////////
    


  71. 

  72. AddDocTransServer::AddDocTransServer()
    

  73. {
    

  74.         
    

  75. }
    


  76. 

  77. void AddDocTransServer::AddSpacificTransServer(Json::Value& value,TsSession*session)
    

  78. {
    


  79. 

  80. }
    


  81. 

  82. ///////////////////AddOpenofficeTransServer /////////////////
    

  83. AddOpenofficeTransServer::AddOpenofficeTransServer()
    

  84. {
    

  85.         m_tsQueue = &GDocOfficeTsQueue;
    

  86.         m_serverType = "DOC";
    

  87. }
    


  88. 

  89. AddOpenofficeTransServer& AddOpenofficeTransServer::GetInstance()
    

  90. {
    

  91.         static  AddOpenofficeTransServer instance_;
    

  92.         return instance_;         
    

  93. }
    


  94. 

  95. void AddOpenofficeTransServer::AddSpacificTransServer(Json::Value& value,TsSession*session)
    

  96. {
    

  97.         
    

  98.         if(value["servertype"] == m_serverType){
    

  99.                 AddTsTransaction(value,session);
    


  100. 

  101.         } else {
    

  102.                 AddTransServer::AddSpacificTransServer(value,session);
    

  103.         }
    

  104. }
    


  105. 

  106. ///////////////////AddWpsTransServer /////////////////
    

  107. AddWpsTransServer::AddWpsTransServer()
    

  108. {
    

  109.         m_tsQueue = &GDocWpsTsQueue;
    

  110.         m_serverType = "DOC_WPS";
    

  111. }
    


  112. 

  113. AddWpsTransServer& AddWpsTransServer::GetInstance()
    

  114. {
    

  115.         static  AddWpsTransServer instance_;
    

  116.         return instance_;         
    

  117. }
    


  118. 

  119. void AddWpsTransServer::AddSpacificTransServer(Json::Value& value,TsSession*session)
    

  120. {
    

  121.         
    

  122.         if(value["servertype"] == m_serverType){
    

  123.                 
    

  124.                 AddTsTransaction(value,session);
    


  125. 

  126.         } else {
    

  127.                 AddTransServer::AddSpacificTransServer(value,session);
    

  128.         }
    

  129. }
    


  130. 

  131. ///////////////////AddOfficeTransServer /////////////////
    

  132. AddOfficeTransServer::AddOfficeTransServer()
    

  133. {
    

  134.         m_tsQueue = &GDocWpsTsQueue;
    

  135.         m_serverType = "DOC_WINDOWS";
    

  136. }
    


  137. 

  138. AddOfficeTransServer& AddOfficeTransServer::GetInstance()
    

  139. {
    

  140.         static  AddOfficeTransServer instance_;
    

  141.         return instance_;         
    

  142. }
    


  143. 

  144. void AddOfficeTransServer::AddSpacificTransServer(Json::Value& value,TsSession*session)
    

  145. {
    


  146. 

  147.         if(value["servertype"] == m_serverType){
    

  148.                 AddTsTransaction(value,session);
    


  149. 

  150.         } else {
    

  151.                 AddTransServer::AddSpacificTransServer(value,session);
    

  152.         }
    

  153. }
    


  154. 

  155. //////////////////// AddVideoTransServer ///////////////////
    


  156. 

  157. AddVideoTransServer::AddVideoTransServer()
    

  158. {
    

  159.         m_tsQueue = &GVideoTsQueue;
    

  160.         m_serverType = "VIDEO";
    

  161. }
    


  162. 

  163. AddVideoTransServer& AddVideoTransServer::GetInstance()
    

  164. {
    

  165.         static  AddVideoTransServer instance_;
    

  166.         return instance_;         
    

  167. }
    


  168. 

  169. void AddVideoTransServer::AddSpacificTransServer(Json::Value& value,TsSession* session)
    

  170. {
    

  171.         
    

  172.         if(value["servertype"].asString() == m_serverType){
    


  173. 

  174.                 AddTsTransaction(value,session);
    


  175. 

  176.         } else {
    

  177.                 AddTransServer::AddSpacificTransServer(value,session);
    

  178.         }
    

  179. }
    


  180. 

  181. ////////////////////// AddDpptTransServer //////////////////
    


  182. 

  183. AddDpptTransServer::AddDpptTransServer()
    

  184. {
    

  185.         m_tsQueue = &GDpptTsQueue;
    

  186.         m_serverType = "DYNAMIC_PPT";
    

  187. }
    


  188. 

  189. AddDpptTransServer& AddDpptTransServer::GetInstance()
    

  190. {
    

  191.         static  AddDpptTransServer instance_;
    

  192.         return instance_;         
    

  193. }
    


  194. 

  195. void AddDpptTransServer::AddSpacificTransServer(Json::Value& value,TsSession*session)
    

  196. {
    

  197.         if(value["servertype"] == m_serverType){
    

  198.                 AddTsTransaction(value,session);
    


  199. 

  200.         } else {
    

  201.                 AddTransServer::AddSpacificTransServer(value,session);
    

  202.         }
    

  203. }
    


  204. 

  205. ///////////////////// TsServerLeave  ////////////////////////////
    


  206. 

  207. TransServerLeave::TransServerLeave()
    

  208. {
    

  209.         m_tsLeaveHandler = &TsVideoLeaveHandler::GetInstance();
    

  210.         m_tsLeaveHandler->add(&TsOpenofficeLeaveHandler::GetInstance());
    

  211.         m_tsLeaveHandler->add(&TsOfficeLeaveHandler::GetInstance());
    

  212.         m_tsLeaveHandler->add(&TsWpsLeaveHandler::GetInstance());
    

  213.         m_tsLeaveHandler->add(&TsDpptLeaveHandler::GetInstance());
    

  214. }
    


  215. 

  216. TransServerLeave& TransServerLeave::GetInstance()
    

  217. {
    

  218.         static  TransServerLeave instance_;
    

  219.         return instance_;         
    

  220. }
    


  221. 

  222. void TransServerLeave::OnServerLeave(TsSession &session)
    

  223. {
    


  224. 

  225. }
    


  226. 

  227. //////////////////////////////// TsLeaveHandler //////////////////////////////
    

  228. TransServer* TsLeaveHandler::FindSession(TsSession* session)
    

  229. {
    

  230.         return m_tsQueue->GetTransServer(session);
    

  231. }
    

  232. ////////////////////////// TsOpenofficeLeaveHandler ///////////////////////////
    

  233. TsOpenofficeLeaveHandler::TsOpenofficeLeaveHandler()
    

  234. {
    

  235.         m_tsQueue = &GDocOpenofficeTsQueue;
    

  236.         m_tsDb = &DocTransServerDb::GetInstance();
    

  237.         m_disptacher = &DocDisptacher::GetInstance();
    

  238. }
    


  239. 

  240. TsOpenofficeLeaveHandler& TsOpenofficeLeaveHandler::GetInstance()
    

  241. {
    

  242.         static TsOpenofficeLeaveHandler instance_;
    

  243.         return instance_;
    


  244. 

  245. }
    


  246. 


  247. 

  248. void TsOpenofficeLeaveHandler::SpacificTsLeave(TsSession* session)
    

  249. {
    

  250.         TransServer* ts;
    

  251.         
    

  252.         ts = FindSession(session);
    

  253.         if(ts != NULL){
    

  254.                 ProcessTsAndTask(ts);
    

  255.         } else {
    

  256.                 TsLeaveHandler::SpacificTsLeave(session);
    

  257.         }
    

  258. }
    


  259. 


  260. 

  261. ////////////////////////// TsOfficeLeaveHandler ///////////////////////////
    

  262. TsOfficeLeaveHandler::TsOfficeLeaveHandler()
    

  263. {
    

  264.         m_tsQueue = &GDocOfficeTsQueue;
    

  265.         m_tsDb = &DocTransServerDb::GetInstance();
    

  266.         m_disptacher = &DocDisptacher::GetInstance();
    

  267. }
    


  268. 

  269. TsOfficeLeaveHandler& TsOfficeLeaveHandler::GetInstance()
    

  270. {
    

  271.         static TsOfficeLeaveHandler instance_;
    

  272.         return instance_;
    


  273. 

  274. }
    


  275. 


  276. 

  277. void TsOfficeLeaveHandler::SpacificTsLeave(TsSession* session)
    

  278. {
    

  279.         TransServer* ts;
    

  280.         
    

  281.         if(ts = FindSession(session)){
    

  282.                 ProcessTsAndTask(ts);
    

  283.         } else {
    

  284.                 TsLeaveHandler::SpacificTsLeave(session);
    

  285.         }
    

  286. }
    


  287. 

  288. ////////////////////////// TsWpsLeaveHandler ///////////////////////////
    

  289. TsWpsLeaveHandler::TsWpsLeaveHandler()
    

  290. {
    

  291.         m_tsQueue = &GDocWpsTsQueue;
    

  292.         m_tsDb = &DocTransServerDb::GetInstance();
    

  293.         m_disptacher = &DocDisptacher::GetInstance();
    

  294. }
    


  295. 

  296. TsWpsLeaveHandler& TsWpsLeaveHandler::GetInstance()
    

  297. {
    

  298.         static TsWpsLeaveHandler instance_;
    

  299.         return instance_;
    


  300. 

  301. }
    


  302. 


  303. 


  304. 

  305. void TsWpsLeaveHandler::SpacificTsLeave(TsSession* session)
    

  306. {
    

  307.         TransServer* ts;
    

  308.         
    

  309.         if(ts = FindSession(session)){
    

  310.                 ProcessTsAndTask(ts);
    

  311.         } else {
    

  312.                 TsLeaveHandler::SpacificTsLeave(session);
    

  313.         }
    

  314. }
    


  315. 


  316. 


  317. 

  318. /////////////////////////// TsVideoLeaveHandler //////////////////////////////
    

  319. TsVideoLeaveHandler::TsVideoLeaveHandler()
    

  320. {
    

  321.         m_tsQueue = &GVideoTsQueue;
    

  322.         m_tsDb = &VideoTransServerDb::GetInstance();
    

  323.         m_disptacher = &VideoDisptacher::GetInstance();
    

  324. }
    


  325. 

  326. TsVideoLeaveHandler& TsVideoLeaveHandler::GetInstance()
    

  327. {
    

  328.         static TsVideoLeaveHandler instance_;
    

  329.         return instance_;
    

  330. }
    


  331. 


  332. 

  333. void TsVideoLeaveHandler::SpacificTsLeave(TsSession* session)
    

  334. {
    

  335.         TransServer* ts;
    

  336.         
    

  337.         if(ts = FindSession(session)){
    

  338.                 ProcessTsAndTask(ts);
    

  339.         } else {
    

  340.                 TsLeaveHandler::SpacificTsLeave(session);
    

  341.         }
    

  342. }
    


  343. 

  344. /////////////////////////// TsDpptLeaveHandler ////////////////////////////////
    

  345. TsDpptLeaveHandler::TsDpptLeaveHandler()
    

  346. {
    

  347.         m_tsQueue = &GDpptTsQueue;
    

  348.         m_tsDb = &DpptTransServerDb::GetInstance();
    

  349.         m_disptacher = &DpptDisptacher::GetInstance();
    

  350. }
    


  351. 

  352. TsDpptLeaveHandler& TsDpptLeaveHandler::GetInstance()
    

  353. {
    

  354.         static TsDpptLeaveHandler instance_;
    

  355.         return instance_;
    

  356. }
    


  357. 


  358. 

  359. void TsDpptLeaveHandler::SpacificTsLeave(TsSession* session)
    

  360. {
    

  361.         TransServer* ts;
    

  362.         
    

  363.         if(ts = FindSession(session)){
    

  364.                 ProcessTsAndTask(ts);
    

  365.         } else {
    

  366.                 TsLeaveHandler::SpacificTsLeave(session);
    

  367.         }
    

  368. }
    


  369.
回复 赏

收藏2 举报

 楼主| keer_zu 发表于 2016-6-8 11:54 | 显示全部楼层
TsQueue.h


复制
  1. #ifndef __TS_QUEUE_H__
    

  2. #define __TS_QUEUE_H__
    


  3. 

  4. #include <list>
    

  5. #include "TransServer.h"
    


  6. 

  7. class TsQueue
    

  8. {
    

  9. public:
    

  10.         bool PushTs(TransServer* ts);
    

  11.         TransServer* GetTsInSpecId(string tsId);
    

  12.         bool DelTs(string tsId);
    

  13.         bool DelTs(TransServer *ts);
    

  14.         bool CheckSameTs(string tsId);
    


  15. 

  16.         TransServer* GetTsIdle();
    

  17.         TransServer* GetTransServer(TsSession* session);
    

  18. private:
    

  19.         list<TransServer *> m_tsList;
    

  20. };
    


  21. 


  22. 


  23. 

  24. #endif
回复 赏

收藏2 举报

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

本版积分规则

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

1482

主题

12925

帖子

55

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