mod_mediacontroller.cpp 69 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265
  1. #include "stdafx.h"
  2. #include "y2k_time.h"
  3. #include "capture.h"
  4. #include "Event.h"
  5. #include "../../Other/libaudiorender/iaudiorenderinterface.h"
  6. #include "mod_mediacontroller.h"
  7. #include "../mod_snapshot/Event.h"
  8. #define AUTOMATCH_CAMERA_ENV "ENV_"
  9. #define AUTOMATCH_CAMERA_OPT "OPT_"
  10. static void __audiomgrlog(void* user_data, const char* fmt, va_list arg)
  11. {
  12. //vDbg(fmt, arg);
  13. int n = _vscprintf(fmt, arg);
  14. if (n >= MAX_PATH) {
  15. char* buf = (char*)malloc((size_t)(n + 1));
  16. vsnprintf(buf, n + 1, fmt, arg);
  17. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("%s", buf);
  18. free(buf);
  19. }
  20. else{
  21. char strlog[MAX_PATH] = {0};
  22. vsnprintf(strlog, MAX_PATH, fmt, arg);
  23. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("%s", strlog);
  24. }
  25. }
  26. void CMediaControllerEntity::OnSysVarEvent(const char *pszKey, const char *pszValue,const char *pszOldValue,const char *pszEntityName)
  27. {
  28. if (_stricmp(pszKey, SYSVAR_CALLTYPE) == 0)
  29. {
  30. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("sys call type from: %c to %c", pszOldValue[0], pszValue[0]);
  31. if(pszValue[0] == CALLTYPE_NORMAL)
  32. {
  33. m_nSysCallType = 0;
  34. }
  35. else if(pszValue[0] == CALLTYPE_MOBILE)
  36. {
  37. m_nSysCallType = 1;
  38. }
  39. else
  40. {
  41. m_nSysCallType = -1;
  42. }
  43. }
  44. }
  45. void CMediaControllerEntity::OnPreStart(CAutoArray<CSimpleStringA> strArgs,CSmartPointer<ITransactionContext> pTransactionContext)
  46. {
  47. m_eDeviceType = eStand2sType;
  48. g_eDeviceType = eStand2sType;
  49. LOG_FUNCTION();
  50. //is Pad Version
  51. m_eDeviceType = RvcGetDeviceType();
  52. g_eDeviceType = m_eDeviceType;
  53. CSmartPointer<IEntityFunction> Func = GetFunction();
  54. CSimpleStringA strValue;
  55. Func->RegistSysVarEvent(SYSVAR_CALLTYPE, this);
  56. Func->GetSysVar(SYSVAR_CALLTYPE, strValue);
  57. if (strValue[0] == CALLTYPE_NORMAL) {
  58. m_nSysCallType = 0;
  59. }
  60. else if (strValue[0] == CALLTYPE_MOBILE) {
  61. m_nSysCallType = 1;
  62. }
  63. else {
  64. assert(0);
  65. }
  66. #ifdef RVC_OS_LINUX
  67. {
  68. audiomgr_callback_t t_callback = { 0 };
  69. t_callback.debug = &__audiomgrlog;
  70. m_pAudioCap = CreateAudioMgrObj(&t_callback);
  71. if (0 == m_pAudioCap->audio_mgr_initialize()) {
  72. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Audio Manager Initialize success!");
  73. }
  74. else {
  75. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Audio Manager Initialize failed!");
  76. return;
  77. }
  78. }
  79. #endif
  80. if (GetFunction()->RegistSysVarEvent("SessionID", this) != Error_Succeed){
  81. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("register sysvar %s failed!", "SessionID");
  82. }
  83. int i = 0;
  84. if ((ePadtype == m_eDeviceType)||(eMobilePadType == m_eDeviceType)||(eDesk2SType == m_eDeviceType)||(eDesk1SType == m_eDeviceType)||(eDesk2SIntegratedType == m_eDeviceType))
  85. {
  86. m_arrListener.Init(19);
  87. GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_None, Error_IgnoreAll, MOD_EVENT_SNAPSHOT_START_CAPTURE_ENV);
  88. GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_None, Error_IgnoreAll, MOD_EVENT_SNAPSHOT_START_CAPTURE_OPT);
  89. GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_None, Error_IgnoreAll, MOD_EVENT_SNAPSHOT_START_CAPTURE_ENVOPT);
  90. GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_None, Error_IgnoreAll, LOG_EVT_MOD_ASSISCHAN_STARTED_SUCCESS,NULL,false);
  91. GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_Middle, Error_IgnoreAll, EVENT_MOD_CUSTOMERAWARE_BEGIN, NULL, false);
  92. GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_Middle, Error_IgnoreAll, EVENT_MOD_CUSTOMERAWARE_END, NULL, false);
  93. GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_None, Error_IgnoreAll, EVENT_USB_CAMER_INPUT,NULL,false);
  94. GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_None, Error_IgnoreAll, EVENT_USB_CAMER_OUTPUT,NULL,false);
  95. GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_None, Error_IgnoreAll, EVENT_USB_CAMERA_NOT_ONLY,NULL,false);
  96. GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_None, Error_IgnoreAll, LOG_EVT_RECORDFAILED,NULL,false);
  97. GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_None, Error_IgnoreAll, LOG_EVT_UI_RECORDFAILED,NULL,false);
  98. GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_Middle, Error_IgnoreAll, LOG_EVT_BEGIN_CAMERA_CONFIG,NULL,false);
  99. GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_Middle, Error_IgnoreAll, LOG_EVT_END_CAMERA_CONFIG,NULL,false);
  100. GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_None, Error_IgnoreAll, LOG_EVT_UI_STARTREMOTERECORD,NULL,false);
  101. GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_None, Error_IgnoreAll, LOG_EVT_UI_STOPREMOTERECORD,NULL,false);
  102. GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_None, Error_IgnoreAll, LOG_EVT_UI_STARTRECORD,NULL,false);
  103. GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_None, Error_IgnoreAll, LOG_EVT_UI_STOPRECORD,NULL,false);
  104. GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_None, Error_IgnoreAll, LOG_EVT_UI_STARTRECORDPREVIEW,NULL,false);
  105. GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_None, Error_IgnoreAll, LOG_EVT_MOD_SALESRECORDER_STARTED_SUCCESS, NULL, false);
  106. }
  107. else
  108. {
  109. m_arrListener.Init(14);
  110. GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_None, Error_IgnoreAll, MOD_EVENT_SNAPSHOT_START_CAPTURE_ENV);
  111. GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_None, Error_IgnoreAll, MOD_EVENT_SNAPSHOT_START_CAPTURE_OPT);
  112. GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_None, Error_IgnoreAll, MOD_EVENT_SNAPSHOT_START_CAPTURE_ENVOPT);
  113. GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_None, Error_IgnoreAll, LOG_EVT_MOD_ASSISCHAN_STARTED_SUCCESS,NULL,false);
  114. GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_Middle, Error_IgnoreAll, EVENT_MOD_CUSTOMERAWARE_BEGIN, NULL, false);
  115. GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_Middle, Error_IgnoreAll, EVENT_MOD_CUSTOMERAWARE_END, NULL, false);
  116. GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_None, Error_IgnoreAll, LOG_EVT_RECORDFAILED,NULL,false);
  117. GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_None, Error_IgnoreAll, LOG_EVT_UI_RECORDFAILED,NULL,false);
  118. GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_None, Error_IgnoreAll, LOG_EVT_UI_STARTREMOTERECORD,NULL,false);
  119. GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_None, Error_IgnoreAll, LOG_EVT_UI_STOPREMOTERECORD,NULL,false);
  120. GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_None, Error_IgnoreAll, LOG_EVT_UI_STARTRECORD,NULL,false);
  121. GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_None, Error_IgnoreAll, LOG_EVT_UI_STOPRECORD,NULL,false);
  122. GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_None, Error_IgnoreAll, LOG_EVT_UI_STARTRECORDPREVIEW,NULL,false);
  123. GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_None, Error_IgnoreAll, LOG_EVT_MOD_SALESRECORDER_STARTED_SUCCESS, NULL, false);
  124. }
  125. pTransactionContext->SendAnswer(Error_Succeed);
  126. }
  127. void CMediaControllerEntity::OnStarted()
  128. {
  129. LOG_FUNCTION();
  130. m_bStartCamera = FALSE;
  131. m_bExternControlCam = FALSE;
  132. m_nSysCallType =0;
  133. ErrorCodeEnum Error = Error_Succeed;
  134. //MessageBoxA(0,0,0,0);
  135. m_pMediaControllerChannel = new ChannelMediaControllerClient(this);
  136. if (Error_Succeed == ConnectAssistChannel()) {
  137. m_bConnectedAssist = TRUE;
  138. }
  139. m_pSelfcheckClient = new SelfChekerClient(this);
  140. Error = m_pSelfcheckClient->Connect();
  141. if (Error != Error_Succeed){
  142. m_pSelfcheckClient->SafeDelete();
  143. m_pSelfcheckClient = NULL;
  144. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("SelfcheckClient connect fail!");
  145. }
  146. else{
  147. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("SelfcheckClient connect success!");
  148. }
  149. #ifdef RVC_OS_WIN
  150. m_pAudioRenderObj = CreateIAudioRenderObj();
  151. if (NULL != m_pAudioRenderObj) {
  152. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("create audio render success, and addr is 0x%08x.", m_pAudioRenderObj);
  153. }
  154. else {
  155. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("create audio render failed.");
  156. }
  157. #else
  158. #endif // RVC_OS_WIN
  159. if (Error_Succeed == GetSalesRecordAudioParam()) {
  160. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("get sales record audio param success, and sales audio capture sample rate is %d, record local PCM flag is %s.", m_nSalesAudioSmpPsec, m_bRecordPCM ? "true" : "false");
  161. }
  162. memset(&conf, 0, sizeof(capture_config_t));
  163. memset(&m_sales_audio_conf, 0, sizeof(rvc_audio_capture_config_t));
  164. Error = (ErrorCodeEnum)capture_lib_init();
  165. if (Error == Error_Succeed)
  166. {
  167. #ifdef RVC_OS_LINUX
  168. RvcGetAudioDevice();
  169. #endif
  170. Error = LoadConfig(&conf);
  171. if (Error != Error_Succeed)
  172. {
  173. if ((Error == Error_OptCamera) || (Error == Error_EnvCamera))
  174. {
  175. if (Error == Error_EnvCamera)
  176. {
  177. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Load EnvCamera Config failed!");
  178. SetCameraSysVar(CAMERA_ENV_ERROR);
  179. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Camera State to CAMERA_ENV_ERROR");
  180. m_nCameraErrorCode = Error_EnvCamera;
  181. GetFunction()->SetUserDefineState(USER_MEDIA_ENVERRROR);
  182. }
  183. else if (Error == Error_OptCamera)
  184. {
  185. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Load OptCamera Config failed!");
  186. SetCameraSysVar(CAMERA_OPT_ERROR);
  187. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Camera State to CAMERA_OPT_ERROR");
  188. m_nCameraErrorCode = Error_OptCamera;
  189. GetFunction()->SetUserDefineState(USER_MEDIA_OPTERROR);
  190. }
  191. }
  192. else
  193. {
  194. if (Error == Error_AllCamera)
  195. {
  196. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Load all camera Config failed!");
  197. SetCameraSysVar(CAMERA_BOTH_ERROR);
  198. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Camera State to CAMERA_BOTH_ERROR");
  199. m_nCameraErrorCode = Error_AllCamera;
  200. GetFunction()->SetUserDefineState(USER_MEDIA_ALLERROR);
  201. }
  202. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Load Config failed!");
  203. }
  204. }
  205. if ((ePadtype == m_eDeviceType) || (eMobilePadType == m_eDeviceType) || (eDesk2SType == m_eDeviceType))
  206. {
  207. CAutoArray<CSimpleStringA> hspCams;
  208. auto rc = GetHSPCameras(hspCams);
  209. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("[GetHSPCameras]: (0x%x,%d)", rc, hspCams.GetCount());
  210. if (eDesk2SType == m_eDeviceType)
  211. {
  212. strFrontCam = conf.strVideoEnv;
  213. strRearCam = "$";
  214. // 将内置摄像头写入到运行时配置
  215. SaveInnerCamera();
  216. }
  217. else
  218. {
  219. ErrorCodeEnum ErrCod = LoadRunConfig(strFrontCam, strRearCam);
  220. if (ErrCod == Error_Succeed) {
  221. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("[dbg] Error=0x%x while LoadRunConfig.", ErrCod);
  222. if (strFrontCam.GetLength() <= 1 || strFrontCam != conf.strVideoEnv) {
  223. strFrontCam = conf.strVideoEnv;
  224. if (conf.strVideoOpt.GetLength() <= 1) {
  225. m_nCameraCount = videocap_optdev_fetch(strFrontCam, strEwsCam, hspCams, strRearCam);
  226. }
  227. else { // 如果root.ini中已配置
  228. strRearCam = conf.strVideoOpt;
  229. }
  230. // 将内置摄像头写入到运行时配置
  231. SaveInnerCamera();
  232. }
  233. }
  234. else {
  235. strFrontCam = conf.strVideoEnv;
  236. if (conf.strVideoOpt.GetLength() <= 1) {
  237. m_nCameraCount = videocap_optdev_fetch(strFrontCam, strEwsCam, hspCams, strRearCam);
  238. }
  239. else { // 如果root.ini中已配置
  240. strRearCam = conf.strVideoOpt;
  241. }
  242. // 将内置摄像头写入到运行时配置
  243. SaveInnerCamera();
  244. }
  245. }
  246. // 尝试获取外接摄像头
  247. m_nCameraCount = videocap_outerdev_fetch(strFrontCam, strRearCam, strEwsCam, hspCams, strUSBCam);
  248. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("[dbg] strUSBCam=%s", (LPCTSTR)strUSBCam);
  249. strEnvCam = conf.strVideoEnv;
  250. }
  251. }
  252. else
  253. {
  254. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("capture_lib_init failed!");
  255. }
  256. //PAD版获取客户感知状态
  257. CSimpleStringA strCustomerAware;
  258. if (Error != Error_AllCamera)
  259. {
  260. CSmartPointer<IEntityFunction> Func = GetFunction();
  261. if (Func->RegistSysVarEvent("CustomerHandle", this) != Error_Succeed)
  262. {
  263. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("register sys var %s failed!", "CustomerHandle");
  264. }
  265. else
  266. {
  267. Func->GetSysVar("CustomerHandle", strCustomerAware);
  268. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("CustomerHandle = %s", (LPCTSTR)strCustomerAware);
  269. }
  270. }
  271. //启动摄像头
  272. if ((Error != Error_AllCamera) && (strCustomerAware.GetLength() > 0) && (strCustomerAware[0] != 'N'))
  273. {
  274. Error = StartCamera();
  275. if (Error == Error_Succeed)
  276. {
  277. m_bStartCamera = TRUE;
  278. CSimpleStringA strSessionId;
  279. CSmartPointer<IEntityFunction> Func = GetFunction();
  280. Func->GetSysVar("SessionID", strSessionId);
  281. LogEvent(Severity_Middle, EVENT_MOD_BEGIN_RECORD, strSessionId);
  282. SetCameraSysVar(CAMERA_NO_ERROR);
  283. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Camera State to CAMERA_NO_ERROR");
  284. m_nCameraErrorCode = Error_Succeed;
  285. GetFunction()->SetUserDefineState(USER_MEDIA_IDLE);
  286. }
  287. else
  288. {
  289. if ((Error == Error_EnvCamera) || (Error == Error_OptCamera))
  290. {
  291. CSimpleStringA strSessionId;
  292. CSmartPointer<IEntityFunction> Func = GetFunction();
  293. Func->GetSysVar("SessionID", strSessionId);
  294. LogEvent(Severity_Middle, EVENT_MOD_BEGIN_RECORD, strSessionId);
  295. m_bStartCamera = TRUE;
  296. if (Error == Error_EnvCamera)
  297. {
  298. SetCameraSysVar(CAMERA_ENV_ERROR);
  299. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Camera State to CAMERA_ENV_ERROR");
  300. m_nCameraErrorCode = Error_EnvCamera;
  301. GetFunction()->SetUserDefineState(USER_MEDIA_ENVERRROR);
  302. Error = Error_Succeed;
  303. }
  304. else if (Error == Error_OptCamera)
  305. {
  306. SetCameraSysVar(CAMERA_OPT_ERROR);
  307. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("StartCamera = Error_OptCamera");
  308. m_nCameraErrorCode = Error_OptCamera;
  309. GetFunction()->SetUserDefineState(USER_MEDIA_OPTERROR);
  310. Error = Error_Succeed;
  311. }
  312. }
  313. else if (Error == Error_AllCamera)
  314. {
  315. SetCameraSysVar(CAMERA_BOTH_ERROR);
  316. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Camera State to CAMERA_BOTH_ERROR");
  317. m_nCameraErrorCode = Error_AllCamera;
  318. m_bStartCamera = FALSE;
  319. GetFunction()->SetUserDefineState(USER_MEDIA_ALLERROR);
  320. }
  321. else
  322. {
  323. SetCameraSysVar(Error);
  324. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Camera State to Other Error");
  325. m_nCameraErrorCode = Error;
  326. m_bStartCamera = FALSE;
  327. RealSelfCheck();
  328. }
  329. }
  330. }
  331. }
  332. #ifdef RVC_OS_LINUX
  333. ErrorCodeEnum CMediaControllerEntity::RvcGetAudioDevice()
  334. {
  335. ErrorCodeEnum Error = Error_Param;
  336. if (NULL != m_pAudioCap){
  337. int icountmic = m_pAudioCap->audio_get_device_count(true);
  338. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("audio input device(%d):", icountmic);
  339. int i = 0;
  340. for (; i < icountmic; i++) {
  341. char strname[MAX_PATH] = { 0 };
  342. m_pAudioCap->audio_get_device_name(strname, MAX_PATH, true, i);
  343. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("%d = %s", i, strname);
  344. }
  345. int icountspeaker = m_pAudioCap->audio_get_device_count(false);
  346. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("audio output device(%d):", icountspeaker);
  347. for (i = 0; i < icountspeaker; i++) {
  348. char strname[MAX_PATH] = { 0 };
  349. m_pAudioCap->audio_get_device_name(strname, MAX_PATH, false, i);
  350. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("%d = %s", i, strname);
  351. }
  352. Error = Error_Succeed;
  353. }
  354. return Error;
  355. }
  356. #endif
  357. DeviceTypeEnum CMediaControllerEntity::RvcGetDeviceType()
  358. {
  359. DeviceTypeEnum eType = eStand2sType;
  360. CSmartPointer<IEntityFunction> spFunction = GetFunction();
  361. CSystemStaticInfo stStaticinfo;
  362. spFunction->GetSystemStaticInfo(stStaticinfo);
  363. if (stricmp(stStaticinfo.strMachineType, "RVC.PAD") == 0) {
  364. if (stricmp(stStaticinfo.strSite, "CMB.FLB") == 0) {
  365. eType = eMobilePadType;
  366. }
  367. else {
  368. eType = ePadtype;
  369. }
  370. }
  371. else if (stricmp(stStaticinfo.strMachineType, "RVC.Desk2S") == 0) {
  372. eType = eDesk2SType;
  373. WORD nMajor = stStaticinfo.MachineVersion.GetMajor();
  374. WORD nMinor = stStaticinfo.MachineVersion.GetMinor();
  375. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("MachineVersion is %d.%d", nMajor, nMinor);
  376. if (2 == nMajor) {
  377. eType = eDesk2SIntegratedType;
  378. }
  379. }
  380. else if (stricmp(stStaticinfo.strMachineType, "RPM.Stand1S") == 0) {
  381. eType = eRpm1sType;
  382. }
  383. else if (stricmp(stStaticinfo.strMachineType, "RVC.Desk1S") == 0) {
  384. eType = eDesk1SType;
  385. }
  386. else {
  387. eType = eStand2sType;
  388. }
  389. if (eType >= 0 && eType < sizeof(Device_Type_Table) / sizeof(char*)) {
  390. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("device type is %s.", Device_Type_Table[eType]);
  391. }
  392. return eType;
  393. }
  394. void CMediaControllerEntity::SetCameraSysVar(int n)
  395. {
  396. if (n==0)
  397. {
  398. SetCameraSysVar(CAMERA_OPT_ERROR);
  399. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Camera State to CAMERA_OPT_ERROR");
  400. }
  401. else if (n==1){
  402. SetCameraSysVar(CAMERA_ENV_ERROR);
  403. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Camera State to CAMERA_ENV_ERROR");
  404. }
  405. else if (n==-1){
  406. SetCameraSysVar(CAMERA_BOTH_ERROR);
  407. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Camera State to CAMERA_BOTH_ERROR");
  408. }
  409. else if (n==3){
  410. SetCameraSysVar(CAMERA_NO_ERROR);
  411. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Camera State to CAMERA_NO_ERROR");
  412. }
  413. }
  414. ErrorCodeEnum CMediaControllerEntity::GetSalesRecordAudioParam()
  415. {
  416. CSmartPointer<IConfigInfo> spConfig;
  417. SpIniMappingTable table;
  418. ErrorCodeEnum Error = GetFunction()->OpenConfig(Config_CenterSetting, spConfig);
  419. if (Error == Error_Succeed){
  420. table.AddEntryInt("SalesRecorder", "AudioSampleRate", m_nSalesAudioSmpPsec, 8);
  421. table.AddEntryBoolean("SalesRecorder", "IsRecordPCM", m_bRecordPCM, false);
  422. Error= table.Load(spConfig);
  423. }
  424. if (m_nSalesAudioSmpPsec != 8 && m_nSalesAudioSmpPsec != 16){
  425. m_nSalesAudioSmpPsec = 8;
  426. }
  427. m_nSalesAudioSmpPsec *= 1000;
  428. #ifdef RVC_OS_WIN
  429. #else
  430. m_nSalesAudioSmpPsec = 44100;
  431. #endif
  432. return Error;
  433. }
  434. ErrorCodeEnum CMediaControllerEntity::SetEnvCameraOnSysVar(const CSimpleStringA strOnState)
  435. {
  436. ErrorCodeEnum Error = Error_Succeed;
  437. CSmartPointer<IEntityFunction> spFunction = this->GetFunction();
  438. Error = spFunction->SetSysVar(SYSVAR_ENVCAMERAON, strOnState.GetData());
  439. return Error;
  440. }
  441. ErrorCodeEnum CMediaControllerEntity::SetCameraSysVar(const CSimpleStringA &newVal)
  442. {
  443. CSmartPointer<IEntityFunction> spFunction = this->GetFunction();
  444. CSimpleStringA val = newVal;
  445. if('B' == val[0]){
  446. LogWarn(Severity_Middle, Error_Debug, ERROR_MOD_MEDIACONTROLLER_CONFIG_ALLERROR, "all config cameras error");
  447. }
  448. if (eStand2sType == m_eDeviceType){
  449. return spFunction->SetSysVar(SYSVAR_CAMERASTATE, (LPCTSTR)newVal);
  450. }
  451. switch (val[0])
  452. {
  453. case 'E':
  454. {
  455. if (!strstr((LPCTSTR)strFrontCam,";"))
  456. {
  457. val = val.Append((LPCTSTR)strFrontCam);
  458. }
  459. else
  460. {
  461. val = val.Append((LPCTSTR)strFrontCam.SubString(0,strFrontCam.IndexOf(";")));
  462. }
  463. }
  464. break;
  465. case 'O':
  466. if (!strstr((LPCTSTR)strRearCam,";"))
  467. {
  468. val = val.Append((LPCTSTR)strRearCam);
  469. }
  470. else
  471. {
  472. val = val.Append((LPCTSTR)strRearCam.SubString(0,strRearCam.IndexOf(";")));
  473. }
  474. break;
  475. case 'B':
  476. val = val.Append("内置前、后");
  477. break;
  478. case 'N':
  479. case 'I':
  480. default:
  481. break;
  482. }
  483. return spFunction->SetSysVar(SYSVAR_CAMERASTATE, (LPCTSTR)val);
  484. }
  485. void CMediaControllerEntity::OnPreClose(EntityCloseCauseEnum eCloseCause,CSmartPointer<ITransactionContext> pTransactionContext)
  486. {
  487. LOG_FUNCTION();
  488. CSmartPointer<IEntityFunction> spFunction = GetFunction();
  489. for (int i = 0; i < m_arrListener.GetCount(); ++i)
  490. {
  491. spFunction->UnsubscribeLog(m_arrListener[i]);
  492. }
  493. spFunction->UnregistSysVarEvent(SYSVAR_CALLTYPE);
  494. if (m_capture) {
  495. capture_stop(m_capture);
  496. capture_destroy(m_capture);
  497. m_capture = NULL;
  498. }
  499. if (m_salesaudio_capture){
  500. salesrecord_audio_capture_stop(m_salesaudio_capture);
  501. salesaudio_capture_destroy(m_salesaudio_capture);
  502. m_salesaudio_capture = NULL;
  503. }
  504. #ifdef RVC_OS_WIN
  505. if (NULL != m_pAudioRenderObj) {
  506. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("destroy audio render obj,and it's addr is 0x%08x.", m_pAudioRenderObj);
  507. DestroyIAudioRenderObj(m_pAudioRenderObj);
  508. }
  509. #else
  510. if (NULL != m_pAudioCap){
  511. m_pAudioCap->audio_mgr_terminate();
  512. DestroyIAudioMgrObj(m_pAudioCap);
  513. m_pAudioCap = NULL;
  514. }
  515. #endif // RVC_OS_WIN
  516. capture_lib_term();
  517. pTransactionContext->SendAnswer(Error_Succeed);
  518. }
  519. void CMediaControllerEntity::OnTimeCameraStatusCheck()
  520. {
  521. int env_n, opt_n;
  522. DWORD nLastEnvTime, nLastOptTime;
  523. bool bEnvTimeout = false;
  524. bool bOptTimeout = false;
  525. if (!m_capture){
  526. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("m_capture =Null");
  527. return;
  528. }
  529. if (!m_bStartCamera){
  530. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("m_bStartCamera =false");
  531. return;
  532. }
  533. BOOL bIsPadType = FALSE;
  534. if ((ePadtype == m_eDeviceType) || (eMobilePadType == m_eDeviceType) || (eDesk2SType == m_eDeviceType) || (eDesk1SType == m_eDeviceType) || (eDesk2SIntegratedType == m_eDeviceType))
  535. {
  536. bIsPadType = TRUE;
  537. }
  538. capture_detect_camera_bug(m_capture, &env_n, &opt_n, bIsPadType);
  539. capture_get_last_frametime(m_capture, &nLastEnvTime, &nLastOptTime, bIsPadType);
  540. if (env_n == 0) {
  541. if (m_iEnvEmptyTimes < CAMERA_BUG_THRESHOLD){
  542. m_iEnvEmptyTimes++;
  543. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("get env camera picture fail,Times=%d",m_iEnvEmptyTimes);
  544. }
  545. }
  546. else if (env_n == -1){
  547. m_iEnvEmptyTimes = CAMERA_BUG_THRESHOLD;
  548. }
  549. else {
  550. if (m_iEnvEmptyTimes == CAMERA_BUG_THRESHOLD){
  551. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("env camera get right!");
  552. }
  553. m_iEnvEmptyTimes = 0;
  554. }
  555. //env图像是否超时
  556. if (nLastEnvTime > 0)
  557. {
  558. //DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("now=%d,nLastEnvTime=%d",y2k_time_now(),nLastEnvTime);
  559. if (((y2k_time_now() - nLastEnvTime) > CAMERA_TIMEOUT) && !bEnvTimeout)
  560. {
  561. bEnvTimeout = true;
  562. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("bEnvTimeout");
  563. }
  564. else if (((y2k_time_now() - nLastEnvTime) < CAMERA_TIMEOUT) && bEnvTimeout)
  565. {
  566. bEnvTimeout = false;
  567. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("change env camera from bEnvTimeout to OK");
  568. }
  569. }
  570. //env是否30S没有图像或者图像20秒没有更新
  571. if (((m_iEnvEmptyTimes == CAMERA_BUG_THRESHOLD) || bEnvTimeout) && (m_nCameraErrorCode != Error_EnvCamera) && (m_nCameraErrorCode != Error_AllCamera))
  572. {
  573. char strMessage[MAX_PATH * 2] = { 0 };
  574. get_camera_exception_message(strMessage, MAX_PATH * 2, conf.strVideoEnv, "Env camera bug detected!");
  575. LogWarn(Severity_Middle, Error_Hardware, ERROR_MOD_MEDIACONTROLLER_ENVCAMERA_BUG, strMessage);
  576. if ((ePadtype == m_eDeviceType) || (eMobilePadType == m_eDeviceType) || (eDesk2SType == m_eDeviceType) || (eDesk1SType == m_eDeviceType) || (eDesk2SIntegratedType == m_eDeviceType))
  577. {
  578. m_nCameraErrorCode = Error_AllCamera;
  579. ChangeSysvar(Error_EnvCamera);
  580. if (!m_bIsRemoteRecord) {
  581. RealSelfCheck();
  582. }
  583. return;
  584. }
  585. else{
  586. if (m_nCameraErrorCode == Error_Succeed){
  587. m_nCameraErrorCode = Error_EnvCamera;
  588. ChangeSysvar(m_nCameraErrorCode);
  589. }
  590. else if (m_nCameraErrorCode == Error_OptCamera){
  591. m_nCameraErrorCode = Error_AllCamera;
  592. ChangeSysvar(m_nCameraErrorCode);
  593. if (!m_bIsRemoteRecord) {
  594. RealSelfCheck();
  595. }
  596. return;
  597. }
  598. }
  599. }
  600. else if((m_iEnvEmptyTimes != CAMERA_BUG_THRESHOLD)&&!bEnvTimeout&&((m_nCameraErrorCode == Error_EnvCamera)||(m_nCameraErrorCode == Error_AllCamera)))
  601. {
  602. if ((ePadtype == m_eDeviceType)||(eMobilePadType == m_eDeviceType)||(eDesk2SType == m_eDeviceType)||(eDesk1SType == m_eDeviceType)||(eDesk2SIntegratedType == m_eDeviceType))
  603. {
  604. m_nCameraErrorCode = Error_Succeed;
  605. ChangeSysvar(m_nCameraErrorCode);
  606. }
  607. else{
  608. if (m_nCameraErrorCode == Error_EnvCamera){
  609. m_nCameraErrorCode = Error_Succeed;
  610. ChangeSysvar(m_nCameraErrorCode);
  611. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("changeSysvar to No_Error");
  612. }
  613. else if (m_nCameraErrorCode == Error_AllCamera){
  614. m_nCameraErrorCode = Error_OptCamera;
  615. ChangeSysvar(m_nCameraErrorCode);
  616. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("changeSysvar to Opt_Error");
  617. }
  618. }
  619. }
  620. //opt是否没有图像
  621. if (eStand2sType == m_eDeviceType)
  622. {
  623. if (opt_n == 0)
  624. {
  625. if (m_iOptEmptyTimes < CAMERA_BUG_THRESHOLD)
  626. {
  627. m_iOptEmptyTimes++;
  628. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("get opt camera picture fail, Times=%d",m_iOptEmptyTimes);
  629. }
  630. }
  631. else if (opt_n == -1)
  632. {
  633. m_iOptEmptyTimes = CAMERA_BUG_THRESHOLD;
  634. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("get opt camera picture fail");
  635. }
  636. else
  637. {
  638. if (m_iOptEmptyTimes == CAMERA_BUG_THRESHOLD)
  639. {
  640. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("opt camera get right!");
  641. }
  642. m_iOptEmptyTimes = 0;
  643. }
  644. }
  645. //opt图像是否超时
  646. if ((nLastOptTime > 0) && (eStand2sType == m_eDeviceType))
  647. {
  648. if (((y2k_time_now() - nLastOptTime) > CAMERA_TIMEOUT) && !bOptTimeout)
  649. {
  650. bOptTimeout = true;
  651. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("bOptTimeout");
  652. }
  653. else if (((y2k_time_now() - nLastOptTime) < CAMERA_TIMEOUT) && bOptTimeout)
  654. {
  655. bOptTimeout = false;
  656. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("change opt camera from bOptTimeout to OK");
  657. }
  658. }
  659. //opt是否100S没有图像或者图像20秒没有更新
  660. if(((m_iOptEmptyTimes == CAMERA_BUG_THRESHOLD)||bOptTimeout)&&(m_nCameraErrorCode!=Error_OptCamera)&&(m_nCameraErrorCode!=Error_AllCamera)&&(eStand2sType == m_eDeviceType))
  661. {
  662. char strMessage[MAX_PATH*2] = {0};
  663. get_camera_exception_message(strMessage, MAX_PATH*2, conf.strVideoOpt, "Opt camera bug detected!");
  664. char strInfo[MAX_PATH*2] = {0};
  665. snprintf(strInfo, MAX_PATH*2, "%s and current time = %u, opt last capture time = %u, video queue LastOptTime = %u.",strMessage, y2k_time_now(), m_capture->opt_video->ulastcaptime, nLastOptTime);
  666. LogWarn(Severity_Middle, Error_Hardware, ERROR_MOD_MEDIACONTROLLER_OPECAMERA_BUG, strInfo);
  667. if (m_nCameraErrorCode == Error_Succeed)
  668. {
  669. m_nCameraErrorCode = Error_OptCamera;
  670. ChangeSysvar(m_nCameraErrorCode);
  671. }
  672. else if (m_nCameraErrorCode == Error_EnvCamera)
  673. {
  674. m_nCameraErrorCode = Error_AllCamera;
  675. ChangeSysvar(m_nCameraErrorCode);
  676. if (!m_bIsRemoteRecord) {
  677. RealSelfCheck();
  678. }
  679. return;
  680. }
  681. }
  682. else if((m_iOptEmptyTimes != CAMERA_BUG_THRESHOLD)&&!bOptTimeout&&((m_nCameraErrorCode == Error_OptCamera)||(m_nCameraErrorCode == Error_AllCamera))&&(eStand2sType == m_eDeviceType))
  683. {
  684. if (m_nCameraErrorCode == Error_OptCamera)
  685. {
  686. m_nCameraErrorCode = Error_Succeed;
  687. ChangeSysvar(m_nCameraErrorCode);
  688. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("changeSysvar to No_Error");
  689. }
  690. else if (m_nCameraErrorCode == Error_AllCamera)
  691. {
  692. m_nCameraErrorCode = Error_EnvCamera;
  693. ChangeSysvar(m_nCameraErrorCode);
  694. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("changeSysvar to Env_Error");
  695. }
  696. }
  697. //重启摄像头
  698. if((m_nCameraErrorCode == Error_EnvCamera)&&(m_nEnvCameraRestartNum<CAMERA_RESTARTNUM))
  699. {
  700. if (ReStartCamera(ENVCAMERA) != Error_Succeed)
  701. {
  702. m_nEnvCameraRestartNum++;
  703. }
  704. else
  705. {
  706. m_nEnvCameraRestartNum = 0;
  707. m_nCameraErrorCode = Error_Succeed;
  708. ChangeSysvar(m_nCameraErrorCode);
  709. m_iEnvEmptyTimes = 0;
  710. bEnvTimeout = false;
  711. //重置上次取图像时间,防止出现重启摄像头5s内取不到图像不断重启摄像头问题
  712. nLastEnvTime = y2k_time_now();
  713. }
  714. }
  715. else if((m_nCameraErrorCode == Error_OptCamera)&&(m_nOptCameraRestartNum<CAMERA_RESTARTNUM)&&(eStand2sType == m_eDeviceType))
  716. {
  717. if (ReStartCamera(OPTCAMERA) != Error_Succeed)
  718. m_nOptCameraRestartNum++;
  719. else
  720. {
  721. m_nOptCameraRestartNum = 0;
  722. m_nCameraErrorCode = Error_Succeed;
  723. ChangeSysvar(m_nCameraErrorCode);
  724. m_iOptEmptyTimes = 0;
  725. bOptTimeout = false;
  726. //重置上次取图像时间,防止出现重启摄像头5s内取不到图像不断重启摄像头问题
  727. nLastOptTime = y2k_time_now();
  728. }
  729. }
  730. else if (m_nCameraErrorCode == Error_AllCamera)
  731. {
  732. if (m_nEnvCameraRestartNum<CAMERA_RESTARTNUM)
  733. {
  734. if (ReStartCamera(ENVCAMERA) != Error_Succeed)
  735. m_nEnvCameraRestartNum++;
  736. else
  737. {
  738. m_nEnvCameraRestartNum = 0;
  739. m_nCameraErrorCode = Error_OptCamera;
  740. ChangeSysvar(m_nCameraErrorCode);
  741. m_iEnvEmptyTimes = 0;
  742. bEnvTimeout = false;
  743. }
  744. }
  745. if((m_nOptCameraRestartNum<CAMERA_RESTARTNUM)&&(eStand2sType == m_eDeviceType))
  746. {
  747. if (ReStartCamera(OPTCAMERA) != Error_Succeed)
  748. m_nOptCameraRestartNum++;
  749. else
  750. {
  751. m_nOptCameraRestartNum = 0;
  752. m_iOptEmptyTimes = 0;
  753. bOptTimeout = false;
  754. if (m_nCameraErrorCode == Error_AllCamera)
  755. {
  756. m_nCameraErrorCode = Error_EnvCamera;
  757. ChangeSysvar(m_nCameraErrorCode);
  758. }
  759. else
  760. {
  761. m_nCameraErrorCode = Error_Succeed;
  762. ChangeSysvar(m_nCameraErrorCode);
  763. }
  764. }
  765. }
  766. }
  767. }
  768. void CMediaControllerEntity::OnTimeout(DWORD dwTimerID)
  769. {
  770. if (dwTimerID == 1) {
  771. OnTimeCameraStatusCheck();
  772. }
  773. else if (2 == dwTimerID) {
  774. if (FALSE == m_bConnectedAssist) {
  775. if (Error_Succeed == ConnectAssistChannel()) {
  776. m_bConnectedAssist = TRUE;
  777. }
  778. }
  779. if (TRUE == m_bConnectedAssist) {
  780. GetFunction()->KillTimer(2);
  781. }
  782. }
  783. }
  784. bool CMediaControllerEntity::SetAutoBright(ErrorCodeEnum nCode)
  785. {
  786. return capture_set_autobrightness(m_capture,nCode);
  787. }
  788. //camera gain adjust
  789. void CMediaControllerEntity::OnReceivePkt(int sub_type, const char *buffer, int size)
  790. {
  791. if (sub_type == ACM_SET_CAMERABRIGHT)
  792. {
  793. if (m_bStartCamera)
  794. {
  795. if (eStand2sType == m_eDeviceType)
  796. {
  797. //vamera bright adj
  798. CCameraBrightValue num;
  799. SpBuffer buf;
  800. buf.OpenRead(buffer,size);
  801. num.Serialize(buf);
  802. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("recv ACM_SET_CAMERABRIGHT = %d",num.nValue);
  803. if (capture_adj_brightness(m_capture,num.nValue,m_nCameraErrorCode) == true)
  804. {
  805. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("ACM_SET_CAMERABRIGHT success!");
  806. SendCameraBright();
  807. }
  808. else
  809. {
  810. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("ACM_SET_CAMERABRIGHT fail!");
  811. }
  812. }
  813. else
  814. {
  815. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("pad type cannot adj brightness");
  816. }
  817. }
  818. else
  819. {
  820. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("the camera not start!");
  821. }
  822. }
  823. }
  824. ErrorCodeEnum CMediaControllerEntity::RealSelfCheck()
  825. {
  826. ErrorCodeEnum Error = Error_Succeed;
  827. if (m_pSelfcheckClient)
  828. {
  829. SelfCheckerService_RealCheck_Req req;
  830. req.name = GetEntityName();
  831. SelfCheckerService_RealCheck_Ans ans;
  832. DWORD Timeout = 500;
  833. Error = m_pSelfcheckClient->RealCheck(req,ans,Timeout);
  834. if (Error!=Error_Succeed)
  835. {
  836. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("RealSelfcheck fail!");
  837. }
  838. else
  839. {
  840. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("RealSelfcheck");
  841. LogWarn(Severity_Low, Error_Debug, LOG_EVT_MEDIACONTROLLER_REAL_SELF_CHECK, "media controller entity auto restart.");
  842. }
  843. }
  844. return Error;
  845. }
  846. void CMediaControllerEntity::SendCameraBright()
  847. {
  848. if (m_nSysCallType == 0)
  849. {
  850. ChannelService_Send_Info Info;
  851. Info.compress = false;
  852. Info.encrypt = false;
  853. Info.type = ACM_TYPE_DEVICE;
  854. Info.id = 0;
  855. Info.sub_type = ACM_CAMERA_BRIGHT;
  856. Info.data.Alloc(sizeof(int));
  857. SpBuffer buf;
  858. buf.OpenWrite();
  859. int nValue = 0;
  860. bool rslt = true;
  861. nValue = capture_get_brightness(m_capture,m_nCameraErrorCode);
  862. if (nValue >= 0)
  863. {
  864. buf & nValue;
  865. Info.data = buf.ToBlob();
  866. m_pMediaControllerChannel->Send(Info);
  867. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("send cur camera bright value = %d",nValue);
  868. }
  869. else
  870. {
  871. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("send cur camera bright value Fail!");
  872. }
  873. }
  874. else
  875. {
  876. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("cur call type cannot send pkt");
  877. }
  878. }
  879. ErrorCodeEnum CMediaControllerEntity::StartEnvCamera()
  880. {
  881. LOG_FUNCTION();
  882. ErrorCodeEnum Error = Error_Succeed;
  883. if (FALSE == m_bStartCamera){
  884. Error = StartCamera();
  885. if (Error_Succeed == Error){
  886. SetCameraSysVar(CAMERA_NO_ERROR);
  887. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Camera State to CAMERA_NO_ERROR");
  888. m_bStartCamera = TRUE;
  889. }
  890. }
  891. else{
  892. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("camera already start.");
  893. }
  894. return Error;
  895. }
  896. ErrorCodeEnum CMediaControllerEntity::StopEnvCamera()
  897. {
  898. LOG_FUNCTION();
  899. if (m_capture){
  900. GetFunction()->KillTimer(1);
  901. capture_stop(m_capture);
  902. capture_destroy(m_capture);
  903. m_capture = NULL;
  904. }
  905. m_bStartCamera = FALSE;
  906. return Error_Succeed;
  907. }
  908. ErrorCodeEnum CMediaControllerEntity::LoadRunConfig(CSimpleStringA& frontcam, CSimpleStringA& rearcam)
  909. {
  910. CSmartPointer<IEntityFunction> spFunction = GetFunction();
  911. CSmartPointer<IConfigInfo> spConfig;
  912. ErrorCodeEnum Error = spFunction->OpenConfig(Config_Run, spConfig);
  913. if (Error == Error_Succeed) {
  914. SpIniMappingTable table;
  915. table.AddEntryString("Video", "FrontCamera", frontcam, "$");
  916. table.AddEntryString("Video", "RearCamera", rearcam, "$");
  917. Error = table.Load(spConfig);
  918. if (Error != Error_Succeed)
  919. {
  920. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("[dbg] failed to load run config.");
  921. }
  922. }
  923. else {
  924. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("[dbg] failed to open run config.");
  925. }
  926. return Error;
  927. }
  928. ErrorCodeEnum CMediaControllerEntity::CheckConfigCameraName(capture_config_t *conf)
  929. {
  930. ErrorCodeEnum Error = Error_Succeed;
  931. int EnvConfigNameError = 0; //0:环境摄像头配置名能成功打开 -1:环境摄像头配置名不能打开 1:未配置环境摄像头名字
  932. int OptConfigNameError = 0; //0:操作摄像头配置名能成功打开 -1:操作摄像头配置名不能打开 1:未配置操作摄像头名字
  933. //check env device
  934. if (conf->strVideoEnv.GetLength() > 1)
  935. { // is not "$"
  936. conf->video_env_dev = capture_get_video_device_id(conf->strVideoEnv.GetData());
  937. if (conf->video_env_dev == -1)
  938. {
  939. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("find strVideoEnv:%s(-1)",(LPCTSTR)conf->strVideoEnv);
  940. EnvConfigNameError = -1;
  941. }
  942. } else
  943. {
  944. conf->video_env_dev = -1;
  945. EnvConfigNameError = 1;
  946. }
  947. //check opt device
  948. if (conf->strVideoOpt.GetLength() > 1)
  949. { // is not "$"
  950. conf->video_opt_dev = capture_get_video_device_id(conf->strVideoOpt.GetData());
  951. if (conf->video_opt_dev == -1)
  952. {
  953. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("find strVideoOpt:%s(-1)",(LPCTSTR)conf->strVideoOpt);
  954. OptConfigNameError = -1;
  955. }
  956. }
  957. else
  958. {
  959. conf->video_opt_dev = -1;
  960. OptConfigNameError = 1;
  961. }
  962. //环境摄像头配置名不能打开
  963. if (EnvConfigNameError == -1){
  964. //操作摄像头配置名不能打开,此时表明摄像头都不可用
  965. if(OptConfigNameError == -1){
  966. Error = Error_AllCamera;
  967. }
  968. //未配置操作摄像头名字or操作摄像头配置名能打开,此时表明只有操作摄像头OK
  969. else{
  970. Error = Error_EnvCamera;
  971. }
  972. }
  973. //环境摄像头配置名能打开
  974. else if (EnvConfigNameError == 0){
  975. //操作摄像头配置名不能打开,此时表明只有环境摄像头OK
  976. if (OptConfigNameError == -1){
  977. Error = Error_OptCamera;
  978. }
  979. //环境摄像头配置名能打开,未配置操作摄像头名字,此时也认为摄像头都OK(无操作摄像头场景)
  980. }
  981. //环境摄像头未配置
  982. else {
  983. //操作摄像头配置名不能打开,此时表明只有操作摄像头OK
  984. if(OptConfigNameError == -1){
  985. Error = Error_OptCamera;
  986. }
  987. //操作摄像头未配置,此时表明摄像头都不可用
  988. else if (OptConfigNameError == 1){
  989. Error = Error_AllCamera;
  990. }
  991. //操作摄像头名字能打开,此时也认为摄像头都OK(无环境摄像头场景)
  992. }
  993. return Error;
  994. }
  995. ErrorCodeEnum CMediaControllerEntity::GetSalesAudioConfig(rvc_audio_capture_config_t *conf, bool bRemoteRecord)
  996. {
  997. CSmartPointer<IEntityFunction> spFunction = GetFunction();
  998. CSmartPointer<IConfigInfo> spConfig;
  999. SpIniMappingTable table;
  1000. ErrorCodeEnum Error = spFunction->OpenConfig(Config_Root, spConfig);
  1001. if (Error == Error_Succeed) {
  1002. CSimpleStringA strAudioInDevice;
  1003. table.AddEntryString("Audio", "sales_record_in_dev", conf->strAudioIn, "$");
  1004. table.AddEntryString("Audio", "handfree_in_dev", strAudioInDevice, "$");
  1005. table.AddEntryString("Audio", "handfree_out_dev", conf->strAudioOut, "$");
  1006. Error = table.Load(spConfig);
  1007. if (Error == Error_Succeed){
  1008. conf->audio_capture_period = CAPTURE_FRAME_TIME;
  1009. conf->audio_capture_samplerate = m_nSalesAudioSmpPsec;
  1010. if (conf->strAudioIn==""){
  1011. conf->strAudioIn = strAudioInDevice;
  1012. }
  1013. }
  1014. else {
  1015. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("load sales audio device config failed!");
  1016. }
  1017. }
  1018. else {
  1019. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("open sales audio device config failed!");
  1020. }
  1021. if (Error_Succeed != Error){
  1022. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("get sales audio device info failed, now get from default value.");
  1023. m_sales_audio_conf.strAudioIn = this->conf.strAudioIn;
  1024. m_sales_audio_conf.audio_capture_period = CAPTURE_FRAME_TIME;
  1025. m_sales_audio_conf.audio_capture_samplerate = CAPTURE_CLOCK;
  1026. Error = Error_Succeed;
  1027. }
  1028. conf->audio_capture_samplerate = CAPTURE_CLOCK*2;
  1029. if (true == bRemoteRecord){
  1030. if (CAPTURE_CLOCK*2 == m_sales_audio_conf.audio_capture_samplerate){
  1031. m_sales_audio_conf.audio_capture_samplerate = CAPTURE_CLOCK;
  1032. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("remote record, change audio sample rate to from %d to %d.", CAPTURE_CLOCK*2, m_sales_audio_conf.audio_capture_samplerate);
  1033. }
  1034. }
  1035. return Error;
  1036. }
  1037. ErrorCodeEnum CMediaControllerEntity::AutoGetVideoDeviceName(capture_config_t* conf)
  1038. {
  1039. ErrorCodeEnum Error = Error_Unexpect;
  1040. int icount = rvc_videocap_get_device_count();
  1041. int ifound = 0;
  1042. bool benv = false;
  1043. bool bopt = false;
  1044. for (int i = 0; i < 64 && ifound < icount; ++i) {
  1045. char strfullname[2 * MAX_PATH] = { 0 };
  1046. if (0 == rvc_videocap_get_device_fullpathname(i, strfullname, 2 * MAX_PATH)) {
  1047. ifound++;
  1048. if (NULL != strstr(strfullname, AUTOMATCH_CAMERA_ENV)) {
  1049. conf->strVideoEnv = strfullname;
  1050. benv = true;
  1051. }
  1052. if (NULL != strstr(strfullname, AUTOMATCH_CAMERA_OPT)) {
  1053. conf->strVideoOpt = strfullname;
  1054. bopt = true;
  1055. }
  1056. if (benv && bopt){
  1057. Error = Error_Succeed;
  1058. break;
  1059. }
  1060. }
  1061. }
  1062. return Error;
  1063. }
  1064. static CSimpleStringA generateCameraInfosJson(CSimpleStringA strEnv, CSimpleStringA strOpt, int iEnv, int iOpt, int iMtu)
  1065. {
  1066. return CSimpleStringA::Format("{\"EnvCamera\":\"%s\",\"OptCamera\":\"%s\",\"EnvRotate\":\"%d\",\"OptRotate\":\"%d\",\"mtu\":\"%d\"}",
  1067. strEnv.GetData(), strOpt.GetData(), iEnv, iOpt, iMtu);
  1068. }
  1069. ErrorCodeEnum CMediaControllerEntity::LoadConfig(capture_config_t *conf)
  1070. {
  1071. CSmartPointer<IEntityFunction> spFunction = GetFunction();
  1072. CSmartPointer<IConfigInfo> spConfig;
  1073. SpIniMappingTable table;
  1074. strEwsCam = "$";
  1075. ErrorCodeEnum Error = spFunction->OpenConfig(Config_Root, spConfig);
  1076. if (Error == Error_Succeed) {
  1077. int imtu = 0;
  1078. table.AddEntryString("Audio", "handfree_in_dev", conf->strAudioIn, "$");
  1079. table.AddEntryString("Audio", "handfree_out_dev", conf->strAudioOut, "$");
  1080. table.AddEntryString("Video", "EnvCamera", conf->strVideoEnv, "$");
  1081. table.AddEntryString("Video", "OptCamera", conf->strVideoOpt, "$");
  1082. table.AddEntryString("Video", "EwsCamera", strEwsCam, "$");
  1083. table.AddEntryInt("Video", "EnvRotate", conf->video_env_rotate, 0);
  1084. table.AddEntryInt("Video", "OptRotate", conf->video_opt_rotate, 0);
  1085. table.AddEntryInt("Video", "EnvFps", conf->video_env_fps, 0);
  1086. table.AddEntryInt("Video", "OptFps", conf->video_opt_fps, 0);
  1087. table.AddEntryInt("Video", "mtu", imtu, 0);
  1088. Error = table.Load(spConfig);
  1089. if (Error == Error_Succeed)
  1090. {
  1091. LogWarn(Severity_Low, Error_Debug, ERROR_MOD_MEDIACONTROLLER_ENV_CAMERA_INFO, conf->strVideoEnv.GetData());
  1092. LogWarn(Severity_Low, Error_Debug, ERROR_MOD_MEDIACONTROLLER_OPT_CAMERA_INFO, conf->strVideoOpt.GetData());
  1093. LogWarn(Severity_Low, Error_Debug, LOG_EVT_MEDIACONTROLLER_CAMERA_INFOS, generateCameraInfosJson(conf->strVideoEnv, conf->strVideoOpt, conf->video_env_rotate, conf->video_opt_rotate, imtu).GetData());
  1094. char strInfo[MAX_PATH * 2] = { 0 };
  1095. Error = AutoGetVideoDeviceName(conf);
  1096. snprintf(strInfo, MAX_PATH * 2, "env = %s,opt = %s", conf->strVideoEnv.GetData(), conf->strVideoOpt.GetData());
  1097. if (Error_Succeed == Error){
  1098. LogWarn(Severity_Low, Error_Debug, ERROR_MOD_MEDIACONTROLLER_VIDEO_AUTO_MATHED_SUCCESS, strInfo);
  1099. }
  1100. else {
  1101. LogWarn(Severity_Low, Error_Debug, ERROR_MOD_MEDIACONTROLLER_VIDEO_AUTO_MATHED_FAILED, strInfo);
  1102. }
  1103. Error = CheckConfigCameraName(conf);
  1104. if (Error == Error_EnvCamera || Error == Error_AllCamera){
  1105. char strMessage[MAX_PATH*2] = {0};
  1106. get_camera_exception_message(strMessage, MAX_PATH*2, conf->strVideoEnv ,"ENV 摄像头打开失败,请检查设备或配置是否正确!");
  1107. LogWarn(Severity_Middle,Error_DevMedia,ERROR_MOD_MEDIACONTROLLER_ENVCAM_INITFAIL, strMessage);
  1108. } else if (Error == Error_OptCamera){
  1109. char strMessage[MAX_PATH*2] = {0};
  1110. get_camera_exception_message(strMessage, MAX_PATH*2, conf->strVideoOpt, "OPT 摄像头打开失败,请检查设备或配置是否正确!");
  1111. LogWarn(Severity_Middle,Error_DevMedia,ERROR_MOD_MEDIACONTROLLER_OPTCAM_INITFAIL, strMessage);
  1112. }
  1113. }
  1114. else
  1115. {
  1116. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("load config failed!");
  1117. }
  1118. }
  1119. else
  1120. {
  1121. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("open config failed!");
  1122. }
  1123. return Error;
  1124. }
  1125. void CMediaControllerEntity::OnExternalCameraSwitchFailed(const char* pszFailedMsg)
  1126. {
  1127. // 广播给业务系统
  1128. ExternalCameraSwitchFailed evt;
  1129. evt.failedmsg = CSimpleStringA2W(pszFailedMsg);
  1130. SpSendBroadcast(GetFunction(), SP_MSG_OF(ExternalCameraSwitchFailed), SP_MSG_SIG_OF(ExternalCameraSwitchFailed), evt);
  1131. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("[dbg] ExternalCameraSwitchFailed broadcast sent!");
  1132. CSmartPointer<IEntityFunction> Func = GetFunction();
  1133. CSimpleStringA strValue;
  1134. Func->GetSysVar("DesktopType", strValue);
  1135. if (strValue == CSimpleStringA("U")) {
  1136. #ifdef RVC_OS_WIN
  1137. MessageBoxA(NULL, pszFailedMsg, NULL, MB_SYSTEMMODAL);
  1138. #else
  1139. #endif // RVC_OS_WIN
  1140. }
  1141. }
  1142. void CMediaControllerEntity::OnLog( const CAutoArray<CUUID> &SubIDs, const CUUID nLogID,const LogTypeEnum eLogType, const SeverityLevelEnum eLevel,
  1143. const DWORD dwSysError,const DWORD dwUserCode,const DWORD dwEntityInstanceID, const WORD wEntityDevelID,
  1144. const CAutoArray<DWORD> &Param, const char *pszEntityName, const char *pszModuleName,const char *pszMessage, const linkContext& pLinkInfo)
  1145. {
  1146. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("user_code = 0x%08x", dwUserCode);
  1147. switch (dwUserCode)
  1148. {
  1149. case MOD_EVENT_SNAPSHOT_START_CAPTURE_ENVOPT:
  1150. {
  1151. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("recv MOD_EVENT_SNAPSHOT_START_CAPTURE_ENVOPT");
  1152. #ifdef RVC_OS_WIN
  1153. InterlockedCompareExchange(&m_lCaptureEnvOptCount, 3, 0);
  1154. #else
  1155. pthread_mutex_lock(&m_envopt_mutex);
  1156. LONG* plTemp = &m_lCaptureEnvOptCount;
  1157. if (0 == *plTemp) {
  1158. *plTemp = 3;
  1159. }
  1160. pthread_mutex_unlock(&m_envopt_mutex);
  1161. #endif // RVC_OS_WIN
  1162. }
  1163. break;
  1164. case MOD_EVENT_SNAPSHOT_START_CAPTURE_ENV:
  1165. {
  1166. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("recv MOD_EVENT_SNAPSHOT_START_CAPTURE_ENV");
  1167. #ifdef RVC_OS_WIN
  1168. InterlockedCompareExchange(&m_lCaptureEnvOptCount, 1, 0);
  1169. #else
  1170. pthread_mutex_lock(&m_envopt_mutex);
  1171. LONG* plTemp = &m_lCaptureEnvOptCount;
  1172. if (0 == *plTemp) {
  1173. *plTemp = 1;
  1174. }
  1175. pthread_mutex_unlock(&m_envopt_mutex);
  1176. #endif // RVC_OS_WIN
  1177. }
  1178. break;
  1179. case MOD_EVENT_SNAPSHOT_START_CAPTURE_OPT:
  1180. {
  1181. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("recv MOD_EVENT_SNAPSHOT_START_CAPTURE_OPT");
  1182. #ifdef RVC_OS_WIN
  1183. InterlockedCompareExchange(&m_lCaptureEnvOptCount, 1, 0);
  1184. #else
  1185. pthread_mutex_lock(&m_envopt_mutex);
  1186. LONG* plTemp = &m_lCaptureEnvOptCount;
  1187. if (0 == *plTemp) {
  1188. *plTemp = 1;
  1189. }
  1190. pthread_mutex_unlock(&m_envopt_mutex);
  1191. #endif // RVC_OS_WIN
  1192. }
  1193. break;
  1194. case LOG_EVT_MOD_ASSISCHAN_STARTED_SUCCESS:
  1195. {
  1196. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("recv LOG_EVT_MOD_ASSISCHAN_STARTED_SUCCESS");
  1197. Sleep(800);
  1198. if (m_pMediaControllerChannel != NULL){
  1199. m_pMediaControllerChannel->GetFunction()->CloseSession();
  1200. m_pMediaControllerChannel->SafeDelete();
  1201. m_pMediaControllerChannel = NULL;
  1202. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Close AssistChannel Session ");
  1203. m_bConnectedAssist = FALSE;
  1204. }
  1205. if (Error_Succeed == ConnectAssistChannel()){
  1206. m_bConnectedAssist = TRUE;
  1207. }
  1208. else {
  1209. GetFunction()->SetTimer(2, this, 3350);
  1210. }
  1211. }
  1212. break;
  1213. case EVENT_MOD_CUSTOMERAWARE_BEGIN:
  1214. {
  1215. m_bCustomerwareBegin = true;
  1216. if (!m_bStartCamera&&!m_bExternControlCam)
  1217. {
  1218. StartCameraAndTiggerRecord(pszMessage);
  1219. }
  1220. }
  1221. break;
  1222. case EVENT_MOD_CUSTOMERAWARE_END:
  1223. {
  1224. m_bCustomerwareBegin = false;
  1225. if (m_bStartCamera&&!m_bExternControlCam)
  1226. {
  1227. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("stop camera");
  1228. if (m_capture)
  1229. {
  1230. LogEvent(Severity_Middle, EVENT_MOD_END_RECORD,pszMessage);
  1231. GetFunction()->KillTimer(1);
  1232. capture_stop(m_capture);
  1233. capture_destroy(m_capture);
  1234. m_capture = NULL;
  1235. }
  1236. m_bStartCamera = FALSE;
  1237. }
  1238. }
  1239. break;
  1240. case EVENT_USB_CAMER_INPUT: // add by ly at 20160329
  1241. {
  1242. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("[dbg] usbcam %s inserted.", pszMessage);
  1243. //huchen add for support usb inout,camera config AutoCorrect
  1244. if (m_bCustomerwareBegin){
  1245. if (!m_bStartCamera&&!m_bExternControlCam) {
  1246. CSimpleStringA strSessionId;
  1247. CSmartPointer<IEntityFunction> Func = GetFunction();
  1248. Func->GetSysVar("SessionID", strSessionId);
  1249. StartCameraAndTiggerRecord((LPCTSTR)strSessionId);
  1250. }
  1251. }
  1252. }
  1253. break;
  1254. case EVENT_USB_CAMER_OUTPUT: // add by ly at 20160329
  1255. {
  1256. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("[dbg] usb cam %s removed.", pszMessage);
  1257. int nEnv = capture_get_video_device_id((LPCTSTR)conf.strVideoEnv);
  1258. if(nEnv<0)
  1259. {
  1260. // 对低柜双屏版屏蔽外接摄像头拔出事件 edit by ly@2018/10
  1261. if (eDesk2SType != m_eDeviceType)
  1262. {
  1263. // 广播给业务系统
  1264. ExternalCameraRemoved evt;
  1265. // comment by ly@2019/03/19
  1266. //evt.camname = CSimpleStringA2W(strUSBCam);
  1267. evt.camname = CSimpleStringA2W(pszMessage);
  1268. SpSendBroadcast(GetFunction(), SP_MSG_OF(ExternalCameraRemoved), SP_MSG_SIG_OF(ExternalCameraRemoved), evt);
  1269. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("[dbg] ExternalCameraRemoved broadcast sent!");
  1270. }
  1271. // 停止摄像头 add by ly@2019/03/19
  1272. if (m_bStartCamera&&!m_bExternControlCam)
  1273. {
  1274. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("stop camera");
  1275. if (m_capture)
  1276. {
  1277. LogEvent(Severity_Middle, EVENT_MOD_END_RECORD,pszMessage);
  1278. GetFunction()->KillTimer(1);
  1279. capture_stop(m_capture);
  1280. capture_destroy(m_capture);
  1281. m_capture = NULL;
  1282. }
  1283. m_bStartCamera = FALSE;
  1284. }
  1285. }
  1286. else
  1287. {
  1288. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("[dbg] USBCam(%s) is not the one used now!",pszMessage);
  1289. }
  1290. //strUSBCam = "$";
  1291. }
  1292. break;
  1293. case EVENT_USB_CAMERA_NOT_ONLY: // add by ly at 20160707
  1294. {
  1295. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("[dbg] more than one usb cam detected.");
  1296. OnExternalCameraSwitchFailed(SwitchFailed_NoUnique);
  1297. }
  1298. break;
  1299. case LOG_EVT_RECORDFAILED:
  1300. {
  1301. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("[dbg] record failed event.");
  1302. GetFunction()->KillTimer(1);
  1303. //edit by ly @2018/01/17
  1304. LogEvent(Severity_Middle, EVENT_MOD_END_RECORD, NULL);
  1305. char FaildFlag = pszMessage[0];
  1306. if (FaildFlag == '0')
  1307. {
  1308. GetFunction()->SetTimer(1, this, 5000);
  1309. OnExternalCameraSwitchFailed("本地录音录像失败,已停止!");
  1310. }
  1311. else //if (FaildFlag == '1')
  1312. {
  1313. OnExternalCameraSwitchFailed("本地录音录像设备故障,尝试恢复中(预计10s内),请稍等");
  1314. m_nCameraErrorCode = Error_AllCamera;
  1315. RealSelfCheck(); // 录音录像失败,强行kill实体
  1316. }
  1317. }
  1318. break;
  1319. case LOG_EVT_UI_RECORDFAILED: // add by ly@2018/06/08
  1320. {
  1321. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("[dbg] sales record failed event.");
  1322. GetFunction()->KillTimer(1);
  1323. if (m_bIsRemoteRecord){
  1324. LogEvent(Severity_Middle, LOG_EVT_UI_STOPREMOTERECORD, NULL);
  1325. }
  1326. else{
  1327. LogEvent(Severity_Middle, LOG_EVT_UI_STOPRECORD, NULL);
  1328. }
  1329. GetFunction()->SetTimer(1, this, 5000);
  1330. OnExternalCameraSwitchFailed(pszMessage);
  1331. //char FaildFlag = pszMessage[0];
  1332. //if (FaildFlag == '0')
  1333. //{
  1334. // GetFunction()->SetTimer(1, this, 5000);
  1335. // OnExternalCameraSwitchFailed("现场销售录音录像失败,已停止!");
  1336. //}
  1337. //else //if (FaildFlag == '1')
  1338. //{
  1339. // OnExternalCameraSwitchFailed("现场销售录音录像设备故障,尝试恢复中(预计10s内),请稍等");
  1340. // m_nCameraErrorCode = Error_AllCamera;
  1341. // RealSelfCheck(); // 录音录像失败,强行kill实体
  1342. //}
  1343. }
  1344. break;
  1345. case LOG_EVT_MOD_SALESRECORDER_STARTED_SUCCESS:
  1346. m_bIsRemoteRecord = false;
  1347. break;
  1348. case LOG_EVT_BEGIN_CAMERA_CONFIG:
  1349. {
  1350. ExternStopCamera();
  1351. }
  1352. break;
  1353. case LOG_EVT_END_CAMERA_CONFIG:
  1354. {
  1355. ExternStartCamera();
  1356. }
  1357. break;
  1358. case LOG_EVT_UI_STARTREMOTERECORD:
  1359. {
  1360. m_bIsRemoteRecord = true;
  1361. HandleRemoteRecord(pszMessage);
  1362. }
  1363. break;
  1364. case LOG_EVT_UI_STOPREMOTERECORD:
  1365. {
  1366. m_bIsRemoteRecord = false;
  1367. if (Error_Succeed == StopSalesRecordAudioCapture()){
  1368. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("stop remote sales record audio capture.");
  1369. }
  1370. if (true == m_bHasStartSpeakerRender){
  1371. StopSpeakerAudioRender();
  1372. }
  1373. }
  1374. break;
  1375. case LOG_EVT_UI_STARTRECORD:
  1376. case LOG_EVT_UI_STARTRECORDPREVIEW:
  1377. {
  1378. m_bIsRemoteRecord = false;
  1379. if (false == m_bRecordPCM){
  1380. if (Error_Succeed == StartSalesRecordAudioCapture()){
  1381. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("begin remote sales record audio capture.");
  1382. }
  1383. }
  1384. else{
  1385. HandleSalesRecordPCMAudio(false, pszMessage);
  1386. }
  1387. }
  1388. break;
  1389. case LOG_EVT_UI_STOPRECORD:
  1390. {
  1391. if (Error_Succeed == StopSalesRecordAudioCapture()){
  1392. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("stop sales record audio capture.");
  1393. }
  1394. }
  1395. break;
  1396. default:
  1397. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("unknown event.");
  1398. break;
  1399. }
  1400. }
  1401. void CMediaControllerEntity::OnSelfTest(EntityTestEnum eTestType,CSmartPointer<ITransactionContext> pTransactionContext)
  1402. {
  1403. if (Test_ShakeHand == eTestType)
  1404. {
  1405. if (m_nCameraErrorCode == Error_AllCamera)
  1406. {
  1407. pTransactionContext->SendAnswer(Error_DevMedia);
  1408. }
  1409. else
  1410. {
  1411. pTransactionContext->SendAnswer(Error_Succeed);
  1412. }
  1413. }
  1414. }
  1415. //获取当前使用摄像头,30分钟轮休一次
  1416. int CMediaControllerEntity::GetActiveCamera()
  1417. {
  1418. #ifdef RVC_OS_WIN
  1419. SYSTEMTIME st;
  1420. GetLocalTime(&st);
  1421. if (st.wMinute <= CAMERA_CHANGE_TIMER)
  1422. {
  1423. return ENVCAMERA;
  1424. }
  1425. else if (st.wMinute > CAMERA_CHANGE_TIMER)
  1426. {
  1427. return OPTCAMERA;
  1428. }
  1429. #else
  1430. return ENVCAMERA;
  1431. #endif // RVC_OS_WIN
  1432. }
  1433. ErrorCodeEnum CMediaControllerEntity::ChangeSysvar(ErrorCodeEnum op)
  1434. {
  1435. switch (op)
  1436. {
  1437. case Error_Succeed:
  1438. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Camera State to No_Error");
  1439. SetCameraSysVar(CAMERA_NO_ERROR);
  1440. GetFunction()->SetUserDefineState(USER_MEDIA_IDLE);
  1441. break;
  1442. case Error_EnvCamera:
  1443. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Camera State to Env_Error");
  1444. SetCameraSysVar(CAMERA_ENV_ERROR);
  1445. GetFunction()->SetUserDefineState(USER_MEDIA_ENVERRROR);
  1446. capture_clearsnapshotvideo(m_capture,ENVCAMERA);
  1447. break;
  1448. case Error_OptCamera:
  1449. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Camera State to Opt_Error");
  1450. SetCameraSysVar(CAMERA_OPT_ERROR);
  1451. GetFunction()->SetUserDefineState(USER_MEDIA_OPTERROR);
  1452. capture_clearsnapshotvideo(m_capture,OPTCAMERA);
  1453. break;
  1454. case Error_AllCamera:
  1455. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Camera State to Both_Error");
  1456. SetCameraSysVar(CAMERA_BOTH_ERROR);
  1457. GetFunction()->SetUserDefineState(USER_MEDIA_ALLERROR);
  1458. capture_clearsnapshotvideo(m_capture,AlLCAMERA);
  1459. break;
  1460. default:
  1461. break;
  1462. }
  1463. return Error_Succeed;
  1464. }
  1465. void CMediaControllerEntity::AutoCorrectCameraConfigName(long wait_time)
  1466. {
  1467. ErrorCodeEnum Error = Error_Succeed;
  1468. int one_timeout = 400;
  1469. int retry = 0;
  1470. #ifdef RVC_OS_WIN
  1471. //检查配置名都成功,不用自动纠正
  1472. Error = CheckConfigCameraName(&conf);
  1473. if (Error == Error_Succeed) {
  1474. return;
  1475. }
  1476. #endif // RVC_OS_WIN
  1477. //只针对低柜双屏做自纠正
  1478. if(eDesk2SType != m_eDeviceType){
  1479. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("AutoCorrectCameraConfig failed, DeviceType:%d is not Desk2SType", m_eDeviceType);
  1480. return;
  1481. }
  1482. }
  1483. //开始销售双录音频采集函数
  1484. ErrorCodeEnum CMediaControllerEntity::StartSalesRecordAudioCapture(bool bRemoteRecord, eRvcPCMTransType eType, void* pData)
  1485. {
  1486. ErrorCodeEnum Error = Error_Succeed;
  1487. if (NULL == m_salesaudio_capture){
  1488. memset(&m_sales_audio_conf, 0, sizeof(m_sales_audio_conf));
  1489. GetSalesAudioConfig(&m_sales_audio_conf, bRemoteRecord);
  1490. Error = (ErrorCodeEnum)salesaudio_capture_create(&m_sales_audio_conf, &m_salesaudio_capture);
  1491. if (Error_Succeed == Error){
  1492. Error = SetSalesRecordAudioCaptureTransActionData(eType, pData);
  1493. }
  1494. }
  1495. if (Error_Succeed == Error){
  1496. Error = salesrecord_audio_capture_start(m_salesaudio_capture);
  1497. if (Error_Succeed == Error){
  1498. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("sales record audio capture start success.");
  1499. }
  1500. else{
  1501. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("sales record audio capture start failed for param error.");
  1502. }
  1503. }
  1504. return Error;
  1505. }
  1506. //停止销售双录音频采集函数
  1507. ErrorCodeEnum CMediaControllerEntity::StopSalesRecordAudioCapture()
  1508. {
  1509. salesrecord_audio_capture_stop(m_salesaudio_capture);
  1510. salesaudio_capture_destroy(m_salesaudio_capture);
  1511. m_salesaudio_capture = NULL;
  1512. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("set m_salesaudio_capture to null.");
  1513. return Error_Succeed;
  1514. }
  1515. ErrorCodeEnum CMediaControllerEntity::StartCamera()
  1516. {
  1517. if (m_capture == NULL)
  1518. {
  1519. ErrorCodeEnum Error = Error_Succeed;
  1520. conf.ref_env_capture_count = &m_lCaptureEnvCount;
  1521. conf.ref_opt_capture_count = &m_lCaptureOptCount;
  1522. conf.ref_envopt_capture_count = &m_lCaptureEnvOptCount;
  1523. #ifdef RVC_OS_WIN
  1524. #else
  1525. conf.env_mutex = &m_env_mutex;
  1526. conf.opt_mutex = &m_opt_mutex;
  1527. conf.envopt_mutex = &m_envopt_mutex;
  1528. #endif
  1529. Error = (ErrorCodeEnum)capture_create(&conf, &m_capture);
  1530. if (Error == Error_Succeed)
  1531. {
  1532. #ifdef RVC_OS_WIN
  1533. #else
  1534. m_capture->audio->paudiocap = m_pAudioCap;
  1535. #endif
  1536. Error = capture_start(m_capture);
  1537. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("capture_start Error code=0x%08x",Error);
  1538. if (Error != Error_Succeed)
  1539. {
  1540. if((Error == Error_AudioIN)||(Error == Error_AudioOut))
  1541. {
  1542. return Error;
  1543. }
  1544. else if (Error == Error_AllCamera)
  1545. {
  1546. capture_destroy(m_capture);
  1547. m_capture = NULL;
  1548. return Error;
  1549. }
  1550. else
  1551. {
  1552. SetAutoBright(Error);
  1553. GetFunction()->SetTimer(1, this, 5000);
  1554. if((Error == Error_OptCamera)&&((ePadtype == m_eDeviceType)||(eMobilePadType == m_eDeviceType)||(eDesk2SType == m_eDeviceType)||(eDesk1SType == m_eDeviceType)||(eDesk2SIntegratedType == m_eDeviceType)))
  1555. {
  1556. return Error_Succeed;
  1557. }
  1558. else
  1559. {
  1560. return Error;
  1561. }
  1562. }
  1563. }
  1564. else
  1565. {
  1566. SetAutoBright(Error);
  1567. GetFunction()->SetTimer(1, this, 5000);
  1568. return Error_Succeed;
  1569. }
  1570. }
  1571. else
  1572. {
  1573. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("create capture failed! 0x%08x", Error);
  1574. m_capture = NULL;
  1575. return Error_Unexpect;
  1576. }
  1577. return Error;
  1578. }
  1579. else
  1580. {
  1581. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("m_capture == NULL");
  1582. return Error_Unexpect;
  1583. }
  1584. }
  1585. ErrorCodeEnum CMediaControllerEntity::StartCamera(int nCamera)
  1586. {
  1587. if (m_capture == NULL)
  1588. {
  1589. ErrorCodeEnum Error = Error_Succeed;
  1590. Error = capture_create(&conf, m_capture,nCamera);
  1591. if (Error == Error_Succeed)
  1592. {
  1593. return capture_start(m_capture,nCamera);
  1594. }
  1595. else
  1596. {
  1597. return Error_Hardware;
  1598. }
  1599. }
  1600. else
  1601. {
  1602. return Error_Unexpect;
  1603. }
  1604. }
  1605. void CMediaControllerEntity::StartCameraAndTiggerRecord(const char * strSessionId)
  1606. {
  1607. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("start camera");
  1608. ErrorCodeEnum Error = StartCamera();
  1609. if (Error == Error_Succeed)
  1610. {
  1611. SetCameraSysVar(CAMERA_NO_ERROR);
  1612. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Camera State to CAMERA_NO_ERROR");
  1613. m_bStartCamera = TRUE;
  1614. LogEvent(Severity_Middle, EVENT_MOD_BEGIN_RECORD,strSessionId);
  1615. }
  1616. else
  1617. {
  1618. if (Error == Error_EnvCamera)
  1619. {
  1620. SetCameraSysVar(CAMERA_ENV_ERROR);
  1621. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Camera State to CAMERA_ENV_ERROR");
  1622. m_bStartCamera = TRUE;
  1623. LogEvent(Severity_Middle, EVENT_MOD_BEGIN_RECORD,strSessionId);
  1624. }
  1625. else if (Error == Error_OptCamera)
  1626. {
  1627. SetCameraSysVar(CAMERA_OPT_ERROR);
  1628. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Camera State to CAMERA_OPT_ERROR");
  1629. m_bStartCamera = TRUE;
  1630. LogEvent(Severity_Middle, EVENT_MOD_BEGIN_RECORD,strSessionId);
  1631. }
  1632. else if (Error == Error_AllCamera)
  1633. {
  1634. SetCameraSysVar(CAMERA_BOTH_ERROR);
  1635. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Camera State to CAMERA_BOTH_ERROR");
  1636. m_nCameraErrorCode = Error_AllCamera;
  1637. m_bStartCamera = FALSE;
  1638. GetFunction()->SetUserDefineState(USER_MEDIA_ALLERROR);
  1639. }
  1640. else
  1641. {
  1642. SetCameraSysVar(Error);
  1643. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Camera State to Other Error");
  1644. m_nCameraErrorCode = Error;
  1645. m_bStartCamera = FALSE;
  1646. }
  1647. }
  1648. }
  1649. ErrorCodeEnum CMediaControllerEntity::ReStartCamera(int nCamera)
  1650. {
  1651. if (m_capture != NULL)
  1652. {
  1653. if((StopCamera(m_capture,nCamera)==-1))
  1654. {
  1655. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("ReStartCamera,stop camera fail!");
  1656. }
  1657. Sleep(2000);
  1658. ErrorCodeEnum Error = Error_Succeed;
  1659. Error = capture_create(&conf, m_capture,nCamera);
  1660. if (Error == Error_Succeed)
  1661. {
  1662. Error = capture_start(m_capture,nCamera);
  1663. if (Error != Error_Succeed)
  1664. {
  1665. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("ReStartCamera,capture_start fail!");
  1666. capture_destroy(m_capture,nCamera);
  1667. return Error;
  1668. }
  1669. else
  1670. {
  1671. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("ReStartCamera,camera = %d,success!",nCamera);
  1672. return Error_Succeed;
  1673. }
  1674. }
  1675. else
  1676. {
  1677. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("ReStartCamera,capture_create fail!");
  1678. capture_destroy(m_capture,nCamera);
  1679. return Error;
  1680. }
  1681. }
  1682. else
  1683. {
  1684. return Error_Unexpect;
  1685. }
  1686. }
  1687. CServerSessionBase *CMediaControllerEntity::OnNewSession(const char* pszRemoteEntityName, const char * pszClass)
  1688. {
  1689. LOG_FUNCTION();
  1690. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("%s connected class = %s!", pszRemoteEntityName, pszClass);
  1691. return new MediaServiceSession(this);
  1692. }
  1693. ErrorCodeEnum CMediaControllerEntity::ExternStartCamera()
  1694. {
  1695. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Extern start camera");
  1696. CSimpleStringA strSessionId;
  1697. CSmartPointer<IEntityFunction> Func = GetFunction();
  1698. Func->GetSysVar("SessionID", strSessionId);
  1699. if (!m_bStartCamera)
  1700. {
  1701. StartCameraAndTiggerRecord((LPCTSTR)strSessionId);
  1702. }
  1703. m_bExternControlCam = FALSE;
  1704. return Error_Succeed;
  1705. }
  1706. ErrorCodeEnum CMediaControllerEntity::ExternStopCamera()
  1707. {
  1708. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Extern stop camera");
  1709. if (m_capture)
  1710. {
  1711. LogEvent(Severity_Middle, EVENT_MOD_END_RECORD,NULL);
  1712. GetFunction()->KillTimer(1);
  1713. capture_stop(m_capture);
  1714. capture_destroy(m_capture);
  1715. m_capture = NULL;
  1716. }
  1717. m_bStartCamera = FALSE;
  1718. m_bExternControlCam = TRUE;
  1719. return Error_Succeed;
  1720. }
  1721. ErrorCodeEnum CMediaControllerEntity::SaveInnerCamera()
  1722. {
  1723. if (strFrontCam.GetLength() <= 1) {
  1724. return Error_Resource;
  1725. }
  1726. if (strstr((LPCTSTR)conf.strVideoEnv,(LPCTSTR)strFrontCam)==NULL)
  1727. {
  1728. CSimpleStringA tmp = strRearCam;
  1729. strRearCam = strFrontCam;
  1730. strFrontCam = tmp;
  1731. }
  1732. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("[dbg] strFrontCam: %s, strRearCam: %s", (LPCSTR)strFrontCam, (LPCSTR)strRearCam);
  1733. CSmartPointer<IEntityFunction> spFunction = GetFunction();
  1734. CSmartPointer<IConfigInfo> spConfig;
  1735. ErrorCodeEnum Error = spFunction->OpenConfig(Config_Run, spConfig);
  1736. if (Error == Error_Succeed) {
  1737. SpIniMappingTable table;
  1738. table.AddEntryString("Video", "FrontCamera", strFrontCam, "$");
  1739. table.AddEntryString("Video", "RearCamera", strRearCam, "$");
  1740. Error = table.Save(spConfig);
  1741. if (Error != Error_Succeed)
  1742. {
  1743. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("[dbg] failed to save run config.");
  1744. }
  1745. }
  1746. else {
  1747. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("[dbg] failed to open run config.");
  1748. }
  1749. return Error;
  1750. }
  1751. // 获取高拍仪摄像头(考虑多个高拍仪)
  1752. ErrorCodeEnum CMediaControllerEntity::GetHSPCameras(CAutoArray<CSimpleStringA> &HSPCameras)
  1753. {
  1754. auto rc = Error_Succeed;
  1755. auto pScannerSetClient = new ScannerService_ClientBase(this);
  1756. if (pScannerSetClient->Connect() != Error_Succeed)
  1757. {
  1758. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("连接ScannerSet实体失败");
  1759. pScannerSetClient->SafeDelete();
  1760. pScannerSetClient = NULL;
  1761. rc = Error_DevConnFailed;
  1762. }
  1763. else
  1764. {
  1765. ScannerService_GetOnlineCameras_Req req = {};
  1766. ScannerService_GetOnlineCameras_Ans ans = {};
  1767. rc = pScannerSetClient->GetOnlineCameras(req, ans, 10000);
  1768. if (rc != Error_Succeed)
  1769. {
  1770. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("ScannerSet 调用 GetOnlineCameras 失败: 0x%x", rc);
  1771. }
  1772. else
  1773. {
  1774. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("ScannerSet invokes GetOnlineCameras suc.");
  1775. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Count: %d", ans.devCount);
  1776. if (ans.devCount > 0) {
  1777. for (int i = 0; i < ans.devFriendlyNames.GetCount(); ++i) {
  1778. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("[%d]%s(%d)", i, (LPCTSTR)ans.devFriendlyNames[i],
  1779. ans.devType[i]);
  1780. CapTypeEnum devType = (CapTypeEnum)ans.devType[i];
  1781. if (devType == CAMTYPE_HSPS)
  1782. {
  1783. HSPCameras.Append(ans.devFriendlyNames, i, 1);
  1784. }
  1785. }
  1786. }
  1787. }
  1788. pScannerSetClient->GetFunction()->CloseSession();
  1789. pScannerSetClient = NULL;
  1790. }
  1791. return rc;
  1792. }
  1793. ErrorCodeEnum CMediaControllerEntity::HandleSalesRecordPCMAudio(bool bRemoteRecord, const char *pszMessage, audio_frame* pFrame)
  1794. {
  1795. ErrorCodeEnum Error = Error_Succeed;
  1796. char strSwiftName[MAX_PATH] = {0};
  1797. if (NULL != pszMessage){
  1798. size_t ulen = strlen(pszMessage);
  1799. char *tmp = new char[ulen+1];
  1800. memset(tmp, 0, ulen + 1);
  1801. memcpy(tmp, pszMessage, ulen);
  1802. char *result[16] = {0};
  1803. auto arr1 = CSimpleStringA2W(tmp).Split('@');
  1804. auto arr2 = CAutoArray<CSimpleStringA>(arr1.GetCount());
  1805. for (int i = 0; i < arr1.GetCount(); ++i){
  1806. arr2[i] = CSimpleStringW2A(arr1[i]);
  1807. result[i] = const_cast<LPSTR>(arr2[i].GetData());
  1808. }
  1809. if (arr1.GetCount() > 4){
  1810. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("remote record swift number is %s.", result[4]);
  1811. snprintf(strSwiftName, MAX_PATH, "%s", result[4]);
  1812. }
  1813. delete tmp;
  1814. tmp = NULL;
  1815. }
  1816. char strMicroName[MAX_PATH] = {0};
  1817. CSimpleStringA strTempDir;
  1818. if (Error_Succeed == GetFunction()->GetPath("Temp", strTempDir)){
  1819. snprintf(strMicroName, MAX_PATH, "%s/local_micro_%s.pcm", strTempDir.GetData(), strSwiftName);
  1820. }
  1821. else{
  1822. snprintf(strMicroName, MAX_PATH, "local_micro_%s.pcm", strSwiftName);
  1823. }
  1824. FILE *pRecord = fopen(strMicroName, "wb+");
  1825. if (NULL != pRecord){
  1826. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("fopen %s success.", strMicroName);
  1827. if (Error_Succeed == StartSalesRecordAudioCapture(bRemoteRecord, eSingleWriteLocal, pRecord)){
  1828. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("begin remote sales record audio capture and record local PCM.");
  1829. }
  1830. }
  1831. else{
  1832. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("fopen %s failed.",strMicroName);
  1833. }
  1834. if (true == bRemoteRecord){
  1835. char strSpeakerName[MAX_PATH] = {0};
  1836. if ("" != strTempDir){
  1837. snprintf(strSpeakerName, MAX_PATH, "%s/remote_speaker_%s.pcm", strTempDir.GetData(), strSwiftName);
  1838. }
  1839. else{
  1840. snprintf(strSpeakerName, MAX_PATH, "remote_speaker_%s.pcm", strSwiftName);
  1841. }
  1842. StartSpeakerAudioRender(0, pFrame, strSpeakerName);
  1843. }
  1844. return Error;
  1845. }
  1846. void CMediaControllerEntity::HandleRemoteRecord(const char *pszMessage)
  1847. {
  1848. audio_frame frame;
  1849. frame.bitspersample = 16;
  1850. frame.format = 1;
  1851. frame.framesize = 320;
  1852. frame.nchannels = 1;
  1853. frame.samplespersec = 8000;
  1854. if (true == m_bRecordPCM){
  1855. HandleSalesRecordPCMAudio(true, pszMessage, &frame);
  1856. }
  1857. else{
  1858. if (Error_Succeed == StartSalesRecordAudioCapture(true)){
  1859. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("begin remote sales record audio capture.");
  1860. }
  1861. StartSpeakerAudioRender(0, &frame, NULL);
  1862. }
  1863. }
  1864. ErrorCodeEnum CMediaControllerEntity::StartSpeakerAudioRender(int iQueue, audio_frame* pFrame, const char* strName)
  1865. {
  1866. auto rc = Error_Succeed;
  1867. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("start speak audio render.");
  1868. #ifdef RVC_OS_WIN
  1869. if (NULL != m_pAudioRenderObj) {
  1870. if (0 == m_pAudioRenderObj->StartRender(0, pFrame, strName)) {
  1871. m_bHasStartSpeakerRender = true;
  1872. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("start speak audio render success.");
  1873. }
  1874. }
  1875. #else
  1876. //m_salesaudio_capture->rvc_audio->bputremote = true;
  1877. #endif // RVC_OS_WIN
  1878. return rc;
  1879. }
  1880. ErrorCodeEnum CMediaControllerEntity::StopSpeakerAudioRender()
  1881. {
  1882. auto rc = Error_Succeed;
  1883. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("stop speak audio render.");
  1884. #ifdef RVC_OS_WIN
  1885. if (NULL != m_pAudioRenderObj) {
  1886. m_pAudioRenderObj->StopRender();
  1887. m_bHasStartSpeakerRender = false;
  1888. }
  1889. #else
  1890. //m_salesaudio_capture->rvc_audio->bputremote = false;
  1891. //salesrecord_speaker_audio_capture_stop(m_salesaudio_capture);
  1892. #endif // RVC_OS_WIN
  1893. return rc;
  1894. }
  1895. ErrorCodeEnum CMediaControllerEntity::SetSalesRecordAudioCaptureTransActionData(eRvcPCMTransType eType, void* pData)
  1896. {
  1897. auto rc = Error_Param;
  1898. if (NULL != m_salesaudio_capture){
  1899. if (NULL != m_salesaudio_capture->rvc_audio){
  1900. m_salesaudio_capture->rvc_audio->eType = eType;
  1901. m_salesaudio_capture->rvc_audio->pdata = pData;
  1902. rc = Error_Succeed;
  1903. }
  1904. }
  1905. return rc;
  1906. }
  1907. ErrorCodeEnum CMediaControllerEntity::ConnectAssistChannel()
  1908. {
  1909. if (NULL == m_pMediaControllerChannel) {
  1910. m_pMediaControllerChannel = new ChannelMediaControllerClient(this);
  1911. }
  1912. ErrorCodeEnum Error = m_pMediaControllerChannel->Connect();
  1913. if (Error != Error_Succeed) {
  1914. m_pMediaControllerChannel = NULL;
  1915. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("ChannelMediaControllerClient connect fail!");
  1916. return Error;
  1917. }
  1918. else {
  1919. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("ChannelMediaControllerClient connect success!");
  1920. }
  1921. if (Error_Succeed == Error)
  1922. {
  1923. ChannelService_BeginState_Sub Sub;
  1924. Error = m_pMediaControllerChannel->BeginState(Sub);
  1925. if (Error != Error_Succeed) {
  1926. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("BeginState biz channel failed!");
  1927. m_pMediaControllerChannel->GetFunction()->CloseSession();
  1928. m_pMediaControllerChannel = NULL;
  1929. return Error;
  1930. }
  1931. else {
  1932. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("BeginState biz channel success!");
  1933. }
  1934. }
  1935. if (Error_Succeed == Error)
  1936. {
  1937. ChannelService_BeginRecv_Sub Sub;
  1938. Sub.type = ACM_TYPE_DEVICE;
  1939. Error = m_pMediaControllerChannel->BeginRecv(Sub);
  1940. if (Error != Error_Succeed) {
  1941. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Begin BeginRecv ACM_TYPE_DEVICE failed!");
  1942. m_pMediaControllerChannel->GetFunction()->CloseSession();
  1943. m_pMediaControllerChannel = NULL;
  1944. return Error;
  1945. }
  1946. else {
  1947. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Begin BeginRecv ACM_TYPE_DEVICE success!");
  1948. }
  1949. }
  1950. return Error;
  1951. }
  1952. SelfChekerClient::SelfChekerClient( CMediaControllerEntity *pEntity ) : SelfCheckerService_ClientBase(pEntity)
  1953. {
  1954. }
  1955. ChannelMediaControllerClient::ChannelMediaControllerClient( CMediaControllerEntity *pEntity ) : ChannelService_ClientBase(pEntity)
  1956. {
  1957. }
  1958. void ChannelMediaControllerClient::OnMessage(ErrorCodeEnum Error, ChannelService_State_Info &Msg, CSmartPointer<IReleasable> pData)
  1959. {
  1960. if (Error == Error_Succeed)
  1961. {
  1962. CMediaControllerEntity *pEntity = static_cast<CMediaControllerEntity*>(m_pEntityBase);
  1963. if (Msg.state == eChannelState_Idle)
  1964. {
  1965. if (pEntity->m_bStartCamera)
  1966. {
  1967. if (pEntity->SetAutoBright(pEntity->m_nCameraErrorCode)==false)
  1968. {
  1969. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("SetAutoBright Fail!");
  1970. }
  1971. }
  1972. }
  1973. else if (Msg.state == eChannelState_Connected)
  1974. {
  1975. if (pEntity->m_bStartCamera)
  1976. {
  1977. pEntity->SendCameraBright();
  1978. }
  1979. }
  1980. }
  1981. }
  1982. void ChannelMediaControllerClient::OnMessage( ErrorCodeEnum Error, ChannelService_Packet_Info &Msg, CSmartPointer<IReleasable> pData )
  1983. {
  1984. LOG_FUNCTION();
  1985. if (Error == Error_Succeed)
  1986. {
  1987. CMediaControllerEntity *pEntity = static_cast<CMediaControllerEntity*>(m_pEntityBase);
  1988. pEntity->OnReceivePkt(Msg.sub_type, (const char*)Msg.data.m_pData, Msg.data.m_iLength);
  1989. }
  1990. }
  1991. void MediaServiceSession::Handle_GetVideoDeviceName(SpReqAnsContext<MediaService_GetVideoDeviceName_Req, MediaService_GetVideoDeviceName_Ans>::Pointer ctx)
  1992. {
  1993. CSimpleStringA frontcam = m_pEntity->strFrontCam;
  1994. CSimpleStringA rearcam = m_pEntity->strRearCam;
  1995. if (frontcam.GetLength() > 1 && rearcam.GetLength() > 1)
  1996. {
  1997. ctx->Ans.frontcam = frontcam;
  1998. if (strstr((LPCTSTR)frontcam,";"))
  1999. {
  2000. ctx->Ans.frontcam = frontcam.SubString(0, frontcam.IndexOf(";"));
  2001. }
  2002. ctx->Ans.rearcam = rearcam;
  2003. if (strstr((LPCTSTR)rearcam,";"))
  2004. {
  2005. ctx->Ans.rearcam = rearcam.SubString(0, rearcam.IndexOf(";"));
  2006. }
  2007. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("get camera1 name:%s",m_pEntity->strFrontCam);
  2008. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("get camera2 name:%s",m_pEntity->strRearCam);
  2009. }
  2010. ctx->Answer(Error_Succeed);
  2011. }
  2012. void MediaServiceSession::Handle_StartCamera(SpOnewayCallContext<MediaService_StartCamera_Info>::Pointer ctx)
  2013. {
  2014. m_pEntity->ExternStartCamera();
  2015. }
  2016. void MediaServiceSession::Handle_StopCamera(SpOnewayCallContext<MediaService_StopCamera_Info>::Pointer ctx)
  2017. {
  2018. m_pEntity->ExternStopCamera();
  2019. }
  2020. void MediaServiceSession::Handle_StartEnvCamera(SpReqAnsContext<MediaService_StartEnvCamera_Req, MediaService_StartEnvCamera_Ans>::Pointer ctx)
  2021. {
  2022. LOG_FUNCTION();
  2023. ErrorCodeEnum Error = m_pEntity->StartEnvCamera();
  2024. ctx->Ans.returncod = Error;
  2025. ctx->Answer(Error);
  2026. }
  2027. void MediaServiceSession::Handle_StopEnvCamera(SpOnewayCallContext<MediaService_StopEnvCamera_Info>::Pointer ctx)
  2028. {
  2029. LOG_FUNCTION();
  2030. m_pEntity->StopEnvCamera();
  2031. }
  2032. void MediaServiceSession::Handle_StartSpeakerRender(SpOnewayCallContext<MediaService_StartSpeakerRender_Info>::Pointer ctx)
  2033. {
  2034. LOG_FUNCTION();
  2035. }
  2036. void MediaServiceSession::Handle_StopSpeakerRender(SpOnewayCallContext<MediaService_StopSpeakerRender_Info>::Pointer ctx)
  2037. {
  2038. LOG_FUNCTION();
  2039. if (true == m_pEntity->m_bHasStartSpeakerRender){
  2040. m_pEntity->StopSpeakerAudioRender();
  2041. }
  2042. else{
  2043. DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("speaker audio render already stopped.");
  2044. }
  2045. }
  2046. SP_BEGIN_ENTITY_MAP()
  2047. SP_ENTITY(CMediaControllerEntity)
  2048. SP_END_ENTITY_MAP()