|
|
@@ -0,0 +1,1738 @@
|
|
|
+#include "stdafx.h"
|
|
|
+#include "mod_SalesRecorder.h"
|
|
|
+using namespace SalesRecorder;
|
|
|
+
|
|
|
+#include "rvc_media_common.h"
|
|
|
+#include "fileutil.h"
|
|
|
+#include "array.h"
|
|
|
+#include <memutil.h>
|
|
|
+#include <algorithm>
|
|
|
+#include <Windows.h>
|
|
|
+
|
|
|
+#include "Event.h"
|
|
|
+
|
|
|
+#include "mod_customeraware/Event.h"
|
|
|
+#include "mod_facetracking/sysvar.h"
|
|
|
+
|
|
|
+#include <assert.h>
|
|
|
+
|
|
|
+#include "EventCode.h"
|
|
|
+
|
|
|
+#include "..\\mod_interactivecontrol\\InteractiveControl_client_g.h"
|
|
|
+#include "..\\mod_interactivecontrol\\InteractiveControl_def_g.h"
|
|
|
+#include "../mod_interactivecontrol/Event.h"
|
|
|
+using namespace InteractiveControl;
|
|
|
+
|
|
|
+
|
|
|
+#ifndef RVC_MIN_FILESIZE
|
|
|
+#define RVC_MIN_FILESIZE 10240
|
|
|
+#endif
|
|
|
+
|
|
|
+
|
|
|
+#define SYSVAR_CALLTYPE "CallType"
|
|
|
+#define CALLTYPE_NORMAL 'N' // 呼叫类型，普通模式
|
|
|
+#define CALLTYPE_MOBILE 'M' // 呼叫类型，手机模式
|
|
|
+
|
|
|
+#define MAX_DISK_PERCENT 95 // 磁盘最大占用百分比
|
|
|
+
|
|
|
+static const char* record_failed_case_table[] = {
|
|
|
+ "[RTA3L01] 启动录像失败，初始化失败",
|
|
|
+ "[RTA3L02] 启动录像失败，字体为空，添加水印失败",
|
|
|
+ "[RTA3L03] 开始录像失败，请稍后(约30秒)再试",
|
|
|
+ "[RTA3L04] 录像失败，摄像头故障，获取不到视频，请联系厂商进行维修",
|
|
|
+ "[RTA3L05] 录像失败，获取不到远端音频，请检查风险提示音是否正常播放且音量大小是否正常",
|
|
|
+ "[RTA3L06] 录像失败，麦克风故障，获取不到本地音频，请联系厂商进行维修",
|
|
|
+ "[RTA3L07] 录像失败，系统不支持当前音频采样率",
|
|
|
+ "[RTA3L08] 录像失败，音频流写入失败，请稍后(约30秒)再试",
|
|
|
+ "[RTA3L09] 录像失败，获取不到远端视频，请稍后(约30秒)再试"
|
|
|
+};
|
|
|
+
|
|
|
+
|
|
|
+static BOOL CheckDiskStatus(const char *szRoot, int nPercent, int *pFreeRatio)
|
|
|
+{
|
|
|
+#ifdef RVC_OS_WIN
|
|
|
+ _ULARGE_INTEGER lpFreeBytesAvailableToCaller = {}, lpTotalNumberOfBytes = {}, lpTotalNumberOfFreeBytes = {};
|
|
|
+ BOOL ret = GetDiskFreeSpaceEx(szRoot, &lpFreeBytesAvailableToCaller, &lpTotalNumberOfBytes, &lpTotalNumberOfFreeBytes);
|
|
|
+ if (ret == 0)
|
|
|
+ {
|
|
|
+ DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("CheckDiskStatus.GetDiskFreeSpaceEx failed(%d).",GetLastError());
|
|
|
+ return FALSE;
|
|
|
+ }
|
|
|
+ DWORD dwTotal = lpTotalNumberOfBytes.QuadPart/1048576;
|
|
|
+ DWORD dwTotalFree = lpTotalNumberOfFreeBytes.QuadPart/1048576;
|
|
|
+ int ratio = dwTotalFree*100/dwTotal;
|
|
|
+ *pFreeRatio = ratio;
|
|
|
+ DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("free disk %d MB, %d percent free.\n", dwTotalFree, ratio);
|
|
|
+ //if (ratio < (100-MAX_DISK_PERCENT))
|
|
|
+ if (ratio < (100-nPercent))
|
|
|
+ {
|
|
|
+ return FALSE;
|
|
|
+ }
|
|
|
+ return TRUE;
|
|
|
+#else
|
|
|
+ //todo 调用resourcewatcher
|
|
|
+ return TRUE;
|
|
|
+#endif
|
|
|
+
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+static int hch2int(char hch)
|
|
|
+{
|
|
|
+ if (hch >= '0' && hch <= '9')
|
|
|
+ return hch-'0';
|
|
|
+ else if (hch >= 'a' && hch <= 'f')
|
|
|
+ return hch-'a'+10;
|
|
|
+ else if (hch >= 'A' && hch <= 'F')
|
|
|
+ return hch-'A'+10;
|
|
|
+
|
|
|
+ return 0;
|
|
|
+}
|
|
|
+
|
|
|
+static long hexstr2int(const char *str, int len)
|
|
|
+{
|
|
|
+ long result = 0;
|
|
|
+ if (str && len <= strlen(str)) {
|
|
|
+ for (int i = 0; i < len; ++i) {
|
|
|
+ result += (hch2int(str[i]) << ((len-i-1) << 2));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return result;
|
|
|
+}
|
|
|
+
|
|
|
+static CSimpleStringA VideoSerialID2TimeString(const char *videoserialid)
|
|
|
+{
|
|
|
+ DWORD nTimeTicks = hexstr2int(videoserialid,8);
|
|
|
+ return ((CSmallDateTime)nTimeTicks).ToTimeString();
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+static void CStringSplit(char* str, char** result, const char* del)
|
|
|
+{
|
|
|
+ char *p = strtok(str, del);
|
|
|
+ while(p != NULL)
|
|
|
+ {
|
|
|
+ *result++ = p;
|
|
|
+ p = strtok(NULL, del);
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+// 寻找某目录下与通配符匹配的文件
|
|
|
+static BOOL FindMatchedFile(LPCSTR sFindPath, LPCSTR sFindFileName, ULONGLONG& uCountFile)
|
|
|
+{
|
|
|
+ char sPath[MAX_PATH];
|
|
|
+ ZeroMemory(sPath, MAX_PATH);
|
|
|
+ char sFormatFileName[MAX_PATH + 2] = "*";
|
|
|
+ WIN32_FIND_DATA FindFileData;
|
|
|
+ HANDLE hFind;
|
|
|
+ BOOL fFinished = FALSE;
|
|
|
+
|
|
|
+ strcpy(sFormatFileName, sFindPath);
|
|
|
+ if (sFindPath[strlen(sFindPath) - 1] != SPLIT_SLASH)
|
|
|
+ {
|
|
|
+ strcat(sFormatFileName, SPLIT_SLASH_STR);
|
|
|
+ strcat(sFormatFileName, "*");
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ strcat(sFormatFileName, "*");
|
|
|
+ }
|
|
|
+ strcat(sFormatFileName, sFindFileName);
|
|
|
+ strcat(sFormatFileName, "*");
|
|
|
+
|
|
|
+ hFind = FindFirstFile(sFormatFileName, &FindFileData);
|
|
|
+
|
|
|
+ if (hFind == INVALID_HANDLE_VALUE)
|
|
|
+ {
|
|
|
+ return FALSE;
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ while (!fFinished)
|
|
|
+ {
|
|
|
+ strcpy(sPath, sFindPath);
|
|
|
+ if (sPath[strlen(sPath) - 1] != SPLIT_SLASH)
|
|
|
+ {
|
|
|
+ strcat(sPath, SPLIT_SLASH_STR);
|
|
|
+ }
|
|
|
+ strcat(sPath, FindFileData.cFileName);
|
|
|
+
|
|
|
+ if (!(FILE_ATTRIBUTE_DIRECTORY & FindFileData.dwFileAttributes))
|
|
|
+ {
|
|
|
+ ++uCountFile;
|
|
|
+ }
|
|
|
+
|
|
|
+ if (!FindNextFile(hFind, &FindFileData))
|
|
|
+ {
|
|
|
+ if (GetLastError() == ERROR_NO_MORE_FILES)
|
|
|
+ {
|
|
|
+ fFinished = TRUE;
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ FindClose(hFind);
|
|
|
+ }
|
|
|
+
|
|
|
+ return TRUE;
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+static CSimpleStringA DecryptString(LPCTSTR lpszEncrpyted)
|
|
|
+{
|
|
|
+ if (NULL == lpszEncrpyted) {
|
|
|
+ return CSimpleStringA("");
|
|
|
+ }
|
|
|
+
|
|
|
+ int iEncrypt = 0;
|
|
|
+ int len = strlen(lpszEncrpyted);
|
|
|
+ CSimpleStringA csPlainTxt('\0', (len) / 2 + 1);
|
|
|
+ int iCh = 0;
|
|
|
+ for (int i = 0; i < len; i += 2) {
|
|
|
+ sscanf(lpszEncrpyted + i, "%02X", &iCh);
|
|
|
+ csPlainTxt[i / 2] = (char)(((char)iCh) ^ (128 | (iEncrypt++ & 127)));
|
|
|
+ }
|
|
|
+ return CSimpleStringA((LPCTSTR)csPlainTxt);
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+static unsigned long GetFileSize(const char* pfilename)
|
|
|
+{
|
|
|
+ unsigned long usize = 0;
|
|
|
+ if (NULL == pfilename){
|
|
|
+ return usize;
|
|
|
+ }
|
|
|
+
|
|
|
+ FILE* pFile = fopen(pfilename, "rb");
|
|
|
+ if (pFile){
|
|
|
+ fseek(pFile, 0, SEEK_END);
|
|
|
+ usize = ftell(pFile);
|
|
|
+ fclose(pFile);
|
|
|
+ }
|
|
|
+
|
|
|
+ return usize;
|
|
|
+}
|
|
|
+
|
|
|
+void SalesRecordServiceSession::Handle_GetOFLVideoRecords( SpReqAnsContext<SalesRecorderSerVice_GetOFLVideoRecords_Req, SalesRecorderSerVice_GetOFLVideoRecords_Ans>::Pointer ctx )
|
|
|
+{
|
|
|
+ DbgToBeidou(ctx->link, __FUNCTION__)();
|
|
|
+ ctx->Answer(Error_Succeed);
|
|
|
+}
|
|
|
+
|
|
|
+void SalesRecordServiceSession::Handle_CheckVideoDiskStatus( SpReqAnsContext<SalesRecorderSerVice_CheckVideoDiskStatus_Req, SalesRecorderSerVice_CheckVideoDiskStatus_Ans>::Pointer ctx )
|
|
|
+{
|
|
|
+ DbgToBeidou(ctx->link, __FUNCTION__)();
|
|
|
+ int nFreeRatio = 0;
|
|
|
+ int bSufficient = CheckDiskStatus((LPCTSTR)ctx->Req.DriveLetter,m_pEntity->m_max_disk_percent,&nFreeRatio);
|
|
|
+ ctx->Ans.IsSufficient = bSufficient;
|
|
|
+ ctx->Ans.FreeRatio = nFreeRatio;
|
|
|
+ ctx->Answer(Error_Succeed);
|
|
|
+}
|
|
|
+
|
|
|
+void SalesRecordServiceSession::Handle_PlayVideo(SpReqAnsContext<SalesRecorderSerVice_PlayVideo_Req, SalesRecorderSerVice_PlayVideo_Ans>::Pointer ctx)
|
|
|
+{
|
|
|
+ DbgToBeidou(ctx->link, __FUNCTION__)();
|
|
|
+ ErrorCodeEnum ErrorCode = m_pEntity->HandleDisplayVideo();
|
|
|
+ ctx->Answer(ErrorCode);
|
|
|
+}
|
|
|
+
|
|
|
+void SalesRecordServiceSession::Handle_SaveVideo(SpReqAnsContext<SalesRecorderSerVice_SaveVideo_Req, SalesRecorderSerVice_SaveVideo_Ans>::Pointer ctx)
|
|
|
+{
|
|
|
+ DbgToBeidou(ctx->link, __FUNCTION__)();
|
|
|
+ ErrorCodeEnum ErrorCode = m_pEntity->HandleSaveVideo();
|
|
|
+ ctx->Answer(ErrorCode);
|
|
|
+}
|
|
|
+
|
|
|
+void SalesRecordServiceSession::Handle_StopRecord(SpReqAnsContext<SalesRecorderSerVice_StopRecord_Req, SalesRecorderSerVice_StopRecord_Ans>::Pointer ctx)
|
|
|
+{
|
|
|
+ DbgToBeidou(ctx->link, __FUNCTION__)();
|
|
|
+ ErrorCodeEnum ErrorCode = m_pEntity->HandleStopRecord((LPCTSTR)CSimpleStringW2A(ctx->Req.VideoName));
|
|
|
+ ctx->Answer(ErrorCode);
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+void SalesRecordServiceSession::Handle_SetAudioTransFlag(SpReqAnsContext<SalesRecorderSerVice_SetAudioTransFlag_Req, SalesRecorderSerVice_SetAudioTransFlag_Ans>::Pointer ctx)
|
|
|
+{
|
|
|
+ DbgToBeidou(ctx->link, __FUNCTION__)();
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Audio transmission flag is %s.", ctx->Req.TransFlag ? "true" : "false");
|
|
|
+ ctx->Answer(Error_Succeed);
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+void SalesRecordServiceSession::Handle_StopShowVideo(SpReqAnsContext<SalesRecorderSerVice_StopShowVideo_Req, SalesRecorderSerVice_StopShowVideo_Ans>::Pointer ctx)
|
|
|
+{
|
|
|
+ DbgToBeidou(ctx->link, __FUNCTION__)();
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Stop Show Video.");
|
|
|
+ ErrorCodeEnum ErrorCode = m_pEntity->HandleStopShowVideo();
|
|
|
+ ctx->Answer(ErrorCode);
|
|
|
+}
|
|
|
+
|
|
|
+void SalesRecordServiceSession::Handle_PlaySalesRecord(SpReqAnsContext<SalesRecorderSerVice_PlaySalesRecord_Req, SalesRecorderSerVice_PlaySalesRecord_Ans>::Pointer ctx)
|
|
|
+{
|
|
|
+ DbgToBeidou(ctx->link, __FUNCTION__)();
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Stop Show Video.");
|
|
|
+ ErrorCodeEnum ErrorCode = m_pEntity->HandlePlaySalesRecordVideo(ctx->Req.WndX, ctx->Req.WndY, ctx->Req.WndWidth, ctx->Req.WndHeight);
|
|
|
+ ctx->Answer(ErrorCode);
|
|
|
+}
|
|
|
+
|
|
|
+void SalesRecordServiceSession::Handle_StartRemoteRecord(SpReqAnsContext<SalesRecorderSerVice_StartRemoteRecord_Req, SalesRecorderSerVice_StartRemoteRecord_Ans>::Pointer ctx)
|
|
|
+{
|
|
|
+ DbgToBeidou(ctx->link, __FUNCTION__)();
|
|
|
+ ErrorCodeEnum ErrorCode = m_pEntity->HandleStartRecord(ctx->Req.VideoName.GetData(), true);
|
|
|
+ ctx->Answer(ErrorCode);
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+void SalesRecordServiceSession::Handle_DeleteVideo(SpReqAnsContext<SalesRecorderSerVice_DeleteVideo_Req, SalesRecorderSerVice_DeleteVideo_Ans>::Pointer ctx)
|
|
|
+{
|
|
|
+ DbgToBeidou(ctx->link, __FUNCTION__)();
|
|
|
+ ErrorCodeEnum ErrorCode = m_pEntity->HandleDeleteVideo();
|
|
|
+ ctx->Answer(ErrorCode);
|
|
|
+}
|
|
|
+
|
|
|
+void SalesRecordServiceSession::Handle_AppendWatermark(SpReqAnsContext<SalesRecorderSerVice_AppendWatermark_Req, SalesRecorderSerVice_AppendWatermark_Ans>::Pointer ctx)
|
|
|
+{
|
|
|
+ DbgToBeidou(ctx->link, __FUNCTION__)();
|
|
|
+ ErrorCodeEnum ErrorCode = m_pEntity->HandleVideoAppendWatermark(CSimpleStringW2A(ctx->Req.VideoName).GetData(), CSimpleStringW2A(ctx->Req.Watermark).GetData());
|
|
|
+ ctx->Answer(ErrorCode);
|
|
|
+}
|
|
|
+
|
|
|
+CServerSessionBase * CSalesRecorderEntity::OnNewSession( const char* pszRemoteEntityName, const char * pszClass )
|
|
|
+{
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("%s connected class = %s!", pszRemoteEntityName, pszClass);
|
|
|
+ return new SalesRecordServiceSession(this);
|
|
|
+}
|
|
|
+
|
|
|
+void CSalesRecorderEntity::OnPreStart( CAutoArray<CSimpleStringA> strArgs,CSmartPointer<ITransactionContext> pTransactionContext )
|
|
|
+{
|
|
|
+ ErrorCodeEnum Error = __OnStart(Error_Succeed);
|
|
|
+ pTransactionContext->SendAnswer(Error);
|
|
|
+}
|
|
|
+
|
|
|
+ErrorCodeEnum CSalesRecorderEntity::__OnStart( ErrorCodeEnum preOperationError )
|
|
|
+{
|
|
|
+ //MessageBoxA(0,0,0,0);
|
|
|
+ m_eDeviceType = eStand2sType;
|
|
|
+ m_nSysCallType = 0;
|
|
|
+ m_bNeedRestart = false;
|
|
|
+ m_eAudioOutQuality = eUltraHD;
|
|
|
+ m_bIsAudioNsOn = false;
|
|
|
+ m_iAudioNsPolicy = 2;
|
|
|
+ m_iAudioChannels = 1;
|
|
|
+
|
|
|
+ m_xIdlePre = m_xKernelPre = m_xUserPre = 0;
|
|
|
+
|
|
|
+ if (SetPriorityClass(GetCurrentProcess(), REALTIME_PRIORITY_CLASS)){
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Set Process(%d) RealTime Priority Success.",GetCurrentProcessId());
|
|
|
+ }
|
|
|
+
|
|
|
+ m_eDeviceType = RvcGetDeviceType();
|
|
|
+
|
|
|
+ int iAudioQuality = 3;
|
|
|
+ int iAudioNsPolicy = 2;
|
|
|
+ int iIsAudioNsOn = 0;
|
|
|
+ int iAudioChannels = 1;
|
|
|
+ int iLogLevel = 1;
|
|
|
+ int iLowestLevel = 1;
|
|
|
+ int iRecordType = 0;
|
|
|
+ m_max_disk_percent = MAX_DISK_PERCENT;
|
|
|
+ m_audio_samplerate = 8;
|
|
|
+ CSmartPointer<IConfigInfo> spConfig;
|
|
|
+ CSmartPointer<IEntityFunction> spFunction = GetFunction();
|
|
|
+ if (spFunction->OpenConfig(Config_CenterSetting, spConfig) == Error_Succeed) {
|
|
|
+ spConfig->ReadConfigValueInt("SalesRecorder","MaxDiskPercent",m_max_disk_percent);
|
|
|
+ spConfig->ReadConfigValueInt("SalesRecorder","AudioSampleRate",m_audio_samplerate);
|
|
|
+ spConfig->ReadConfigValueInt("SalesRecorder","AudioBitRate",m_audio_out_bitrate);
|
|
|
+ spConfig->ReadConfigValueInt("SalesRecorder","WholeSection",m_bWholeSection);
|
|
|
+ spConfig->ReadConfigValueInt("SalesRecorder","ApplyHighQuality",m_bApplyHighQuality);
|
|
|
+ spConfig->ReadConfigValueInt("SalesRecorder","AudioNsPolicy",iAudioNsPolicy);
|
|
|
+ spConfig->ReadConfigValueInt("SalesRecorder","IsAudioNsOn",iIsAudioNsOn);
|
|
|
+ spConfig->ReadConfigValueInt("SalesRecorder","AudioQuality",iAudioQuality);
|
|
|
+ spConfig->ReadConfigValueInt("SalesRecorder","AudioChannels",iAudioChannels);
|
|
|
+ spConfig->ReadConfigValueInt("SalesRecorder","LogLevel",iLogLevel);
|
|
|
+ spConfig->ReadConfigValueInt("SalesRecorder","LowestLevel",iLowestLevel);
|
|
|
+ spConfig->ReadConfigValueInt("SalesRecorder", "RecordType", iRecordType);
|
|
|
+ }
|
|
|
+
|
|
|
+ if (m_max_disk_percent <= 0 || m_max_disk_percent >= 100) {
|
|
|
+ m_max_disk_percent = MAX_DISK_PERCENT;
|
|
|
+ }
|
|
|
+
|
|
|
+ if (iLogLevel <= RECORD_LOG_ERROR && iLogLevel > 0){
|
|
|
+ m_loglevel = (record_loglevel)iLogLevel;
|
|
|
+ }
|
|
|
+ DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("m_loglevel:%d", m_loglevel);
|
|
|
+
|
|
|
+ if (iLowestLevel <= RECORD_LOG_ERROR && iLowestLevel > 0){
|
|
|
+ m_lowestlevel = (record_loglevel)iLowestLevel;
|
|
|
+ }
|
|
|
+ DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("m_lowestlevel:%d", m_lowestlevel);
|
|
|
+
|
|
|
+ if (0 != iRecordType) {
|
|
|
+ m_eRecordType = eMP4;
|
|
|
+ }
|
|
|
+
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("video format is %s.", m_eRecordType == eMP4 ? RECORD_MP4_SUFFIX : RECORD_WMV_SUFFIX);
|
|
|
+
|
|
|
+ SetRecordAudioQuality(iAudioQuality);
|
|
|
+ SetRecordAudioNsPolicy(iAudioNsPolicy);
|
|
|
+ SetRecordAudioChannles(iAudioChannels);
|
|
|
+
|
|
|
+ if (0 != iIsAudioNsOn){
|
|
|
+ m_bIsAudioNsOn = true;
|
|
|
+ }
|
|
|
+
|
|
|
+ if (m_bWholeSection != 0 && m_bWholeSection != 1){
|
|
|
+ m_bWholeSection = FALSE;
|
|
|
+ }
|
|
|
+
|
|
|
+ if (m_bApplyHighQuality != 0 && m_bApplyHighQuality != 1){
|
|
|
+ m_bApplyHighQuality = FALSE;
|
|
|
+ }
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("m_bApplyHighQuality:%d",m_bApplyHighQuality);
|
|
|
+
|
|
|
+ if (preOperationError != Error_Succeed) {
|
|
|
+ return preOperationError;
|
|
|
+ }
|
|
|
+
|
|
|
+ ErrorCodeEnum Error = Error_Succeed;
|
|
|
+ m_iActiveCamera = CAMERA_TYPE_ENV;
|
|
|
+ m_iCameraState = 'N';
|
|
|
+
|
|
|
+ int i = 0;
|
|
|
+
|
|
|
+ m_arrListener.Init(3);
|
|
|
+ GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_None, Error_IgnoreAll, LOG_EVT_UI_RETURNMENU, NULL, false);
|
|
|
+ GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_None, Error_IgnoreAll, LOG_EVT_UI_VIDEOAPPENDWATERMARK, NULL, false);
|
|
|
+ GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_High, Error_IgnoreAll, LOG_EVT_SALESRECORD_ENTITY_EXCEPTION, NULL, false);
|
|
|
+
|
|
|
+ GetFunction()->RegistSysVarEvent(SYSVAR_ACTIVETRACKINGCAMERA,this);
|
|
|
+ GetFunction()->RegistSysVarEvent(SYSVAR_CAMERASTATE,this);
|
|
|
+ CSimpleStringA strValue;
|
|
|
+ GetFunction()->GetSysVar(SYSVAR_CAMERASTATE, strValue);
|
|
|
+ m_iCameraState = strValue[0];
|
|
|
+ if (strValue[0] == 'E'){
|
|
|
+ m_iActiveCamera = CAMERA_TYPE_OPT;
|
|
|
+ }
|
|
|
+ else{
|
|
|
+ m_iActiveCamera = CAMERA_TYPE_ENV;
|
|
|
+ }
|
|
|
+
|
|
|
+ GetFunction()->RegistSysVarEvent(SYSVAR_CALLTYPE, this);
|
|
|
+ GetFunction()->GetSysVar(SYSVAR_CALLTYPE, strValue);
|
|
|
+ if (strValue[0] == CALLTYPE_NORMAL) {
|
|
|
+ m_nSysCallType = 0;
|
|
|
+ }
|
|
|
+ else if (strValue[0] == CALLTYPE_MOBILE) {
|
|
|
+ m_nSysCallType = 1;
|
|
|
+ }
|
|
|
+ else {
|
|
|
+ assert(0);
|
|
|
+ }
|
|
|
+
|
|
|
+ Error = GetFunction()->RegistSysVarEvent("SessionID", this);
|
|
|
+ if (Error != Error_Succeed)
|
|
|
+ {
|
|
|
+ DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("register sysvar %s failed!", "SessionID");
|
|
|
+ }
|
|
|
+
|
|
|
+ Error = GetFunction()->GetPath("Temp", m_TempDir);
|
|
|
+ if (Error != Error_Succeed) {
|
|
|
+ DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("get global record temp path failed!");
|
|
|
+ }
|
|
|
+
|
|
|
+ if (m_TempDir.GetLength() > 0 && m_TempDir[m_TempDir.GetLength()-1] != SPLIT_SLASH) {
|
|
|
+ m_TempDir += SPLIT_SLASH_STR;
|
|
|
+ }
|
|
|
+ Error = GetFunction()->GetPath("UploadVideo", m_RecordSaveDir);
|
|
|
+ if (Error != Error_Succeed) {
|
|
|
+ DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("get global record save path failed!");
|
|
|
+ }
|
|
|
+
|
|
|
+ if (m_RecordSaveDir.GetLength() > 0 && m_RecordSaveDir[m_RecordSaveDir.GetLength()-1] != SPLIT_SLASH) {
|
|
|
+ m_RecordSaveDir += SPLIT_SLASH_STR;
|
|
|
+ }
|
|
|
+
|
|
|
+ return Error;
|
|
|
+}
|
|
|
+
|
|
|
+void CSalesRecorderEntity::OnStarted()
|
|
|
+{
|
|
|
+ LogEvent(Severity_Middle, LOG_EVT_MOD_SALESRECORDER_STARTED_SUCCESS, "sales recorder entity started successfully.");
|
|
|
+}
|
|
|
+
|
|
|
+void CSalesRecorderEntity::OnPreClose( EntityCloseCauseEnum eCloseCause,CSmartPointer<ITransactionContext> pTransactionContext )
|
|
|
+{
|
|
|
+ ErrorCodeEnum Error = __OnClose(Error_Succeed);
|
|
|
+ pTransactionContext->SendAnswer(Error);
|
|
|
+}
|
|
|
+
|
|
|
+ErrorCodeEnum CSalesRecorderEntity::__OnClose( ErrorCodeEnum preOperationError )
|
|
|
+{
|
|
|
+ if (preOperationError != Error_Succeed) {
|
|
|
+ return preOperationError;
|
|
|
+ }
|
|
|
+
|
|
|
+ CSmartPointer<IEntityFunction> spFunction = GetFunction();
|
|
|
+ for (int i = 0; i < m_arrListener.GetCount(); ++i) {
|
|
|
+ spFunction->UnsubscribeLog(m_arrListener[i]);
|
|
|
+ }
|
|
|
+
|
|
|
+ GetFunction()->UnregistSysVarEvent(SYSVAR_ACTIVETRACKINGCAMERA);
|
|
|
+ GetFunction()->UnregistSysVarEvent(SYSVAR_CAMERASTATE);
|
|
|
+
|
|
|
+ StopRecord();
|
|
|
+
|
|
|
+ return Error_Succeed;
|
|
|
+}
|
|
|
+
|
|
|
+void CSalesRecorderEntity::OnSelfTest(EntityTestEnum eTestType,CSmartPointer<ITransactionContext> pTransactionContext)
|
|
|
+{
|
|
|
+ if (Test_ShakeHand == eTestType)
|
|
|
+ {
|
|
|
+ if (m_bNeedRestart){
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("[OnSelfTest] entity need restart now.");
|
|
|
+ pTransactionContext->SendAnswer(Error_Unexpect);
|
|
|
+ }
|
|
|
+ else{
|
|
|
+ pTransactionContext->SendAnswer(Error_Succeed);
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+void CSalesRecorderEntity::Debug(record_loglevel elevel, const char *fmt, ...)
|
|
|
+{
|
|
|
+ record_loglevel entitylevel = (m_lowestlevel > m_loglevel) ? m_lowestlevel : m_loglevel;
|
|
|
+
|
|
|
+ if (entitylevel <= elevel) {
|
|
|
+ va_list arg;
|
|
|
+ va_start(arg, fmt);
|
|
|
+
|
|
|
+ int n = _vscprintf(fmt, arg);
|
|
|
+ if (n >= 512) {
|
|
|
+ char* buf = (char*)malloc((size_t)(n + 1));
|
|
|
+ _vsnprintf(buf, n + 1, fmt, arg);
|
|
|
+ DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("%s", buf);
|
|
|
+ free(buf);
|
|
|
+ }
|
|
|
+ else{
|
|
|
+ char strlog[512] = {0};
|
|
|
+ _vsnprintf(strlog, 512, fmt, arg);
|
|
|
+ DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("%s", strlog);
|
|
|
+ }
|
|
|
+ va_end(arg);
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+void CSalesRecorderEntity::vDebug(record_loglevel elevel, const char* str, va_list list)
|
|
|
+{
|
|
|
+ if (RECORD_LOG_INFO <= elevel) {
|
|
|
+ int n = _vscprintf(str, list);
|
|
|
+ if (n >= 512) {
|
|
|
+ char* buf = (char*)malloc((size_t)(n + 1));
|
|
|
+ _vsnprintf(buf, n + 1, str, list);
|
|
|
+ DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("%s", buf);
|
|
|
+ free(buf);
|
|
|
+ }
|
|
|
+ else {
|
|
|
+ char strlog[512] = { 0 };
|
|
|
+ _vsnprintf(strlog, 512, str, list);
|
|
|
+ DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("%s", strlog);
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+int CSalesRecorderEntity::GetActiveCamera()
|
|
|
+{
|
|
|
+ return m_iActiveCamera;
|
|
|
+}
|
|
|
+
|
|
|
+int CSalesRecorderEntity::GetCameraState()
|
|
|
+{
|
|
|
+ //DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("get active camera = %d", m_iCameraState);
|
|
|
+ return m_iCameraState;
|
|
|
+}
|
|
|
+
|
|
|
+void CSalesRecorderEntity::OnRecordFailed(eRvcRecordFailedCase eCase, const char *pszMessage, bool bRecordDevFault)
|
|
|
+{
|
|
|
+ double fCpuUsage = GetSystemCpuUsage();
|
|
|
+ if (fCpuUsage > 50.0){
|
|
|
+ LogWarn(Severity_Low, Error_Debug, LOG_EVT_UI_RECORDFAILED_FOR_HIGHCPU, "more than 50 percent.");
|
|
|
+ }
|
|
|
+
|
|
|
+ if (eCase < eDefault && eCase >= 0){
|
|
|
+ LogEvent(Severity_Middle, LOG_EVT_UI_RECORDFAILED, record_failed_case_table[eCase]);
|
|
|
+ }
|
|
|
+
|
|
|
+ m_loglevel = RECORD_LOG_INFO;
|
|
|
+
|
|
|
+ char strmsg[MAX_PATH] = {0};
|
|
|
+ _snprintf(strmsg, MAX_PATH, "{%s} current memory usage is %d, and cpu usage is %f.",pszMessage ? pszMessage : " ", GetSystemMemoryUsage(), fCpuUsage);
|
|
|
+ LogWarn(Severity_Middle, Error_Debug, LOG_EVT_SALESRECORD_FAILED, strmsg);
|
|
|
+
|
|
|
+ if (eBeginFailed == eCase){
|
|
|
+ m_bNeedRestart = true;
|
|
|
+ RealSelfCheck();
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+void CSalesRecorderEntity::OnRecordEntityExcption()
|
|
|
+{
|
|
|
+ LogEvent(Severity_High,LOG_EVT_SALESRECORD_ENTITY_EXCEPTION,"现场销售双录出现异常，请稍候重录，系统正在恢复中，预计60秒！");
|
|
|
+ LogWarn(Severity_Low, Error_Debug, LOG_EVT_RECORD_ENTITY_EXCEPTION, "sales record entity exception!");
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+void CSalesRecorderEntity::OnRecordFinished()
|
|
|
+{
|
|
|
+ LogEvent(Severity_High, LOG_EVT_SALESRECORD_FINISHED, "现场销售双录已完成.");
|
|
|
+ LogWarn(Severity_Low, Error_Debug, LOG_EVT_RECORD_FINISHED, "现场销售双录已完成.");
|
|
|
+}
|
|
|
+
|
|
|
+void CSalesRecorderEntity::WmpDebug( const char *fmt, ... )
|
|
|
+{
|
|
|
+ va_list arg;
|
|
|
+ va_start(arg, fmt);
|
|
|
+ int n = _vscprintf(fmt, arg);
|
|
|
+ if (n >= 512) {
|
|
|
+ char* buf = (char*)malloc((size_t)(n + 1));
|
|
|
+ _vsnprintf(buf, n + 1, fmt, arg);
|
|
|
+ DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("%s", buf);
|
|
|
+ free(buf);
|
|
|
+ }
|
|
|
+ else {
|
|
|
+ char strlog[512] = { 0 };
|
|
|
+ _vsnprintf(strlog, 512, fmt, arg);
|
|
|
+ DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("%s", strlog);
|
|
|
+ }
|
|
|
+ va_end(arg);
|
|
|
+}
|
|
|
+
|
|
|
+// 定时任务：扫描是否有待提交的离线双录记录 add by ly @2018/02/08
|
|
|
+void CSalesRecorderEntity::OnTimeout( DWORD dwTimerID )
|
|
|
+{
|
|
|
+
|
|
|
+}
|
|
|
+
|
|
|
+void CSalesRecorderEntity::OnSysVarEvent( const char *pszKey, const char *pszValue,const char *pszOldValue,const char *pszEntityName )
|
|
|
+{
|
|
|
+ if (_stricmp(pszKey, SYSVAR_CAMERASTATE) == 0)
|
|
|
+ {
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("camera state from : %c to %c", pszOldValue[0], pszValue[0]);
|
|
|
+ m_iCameraState = pszValue[0];
|
|
|
+ if (pszValue[0] == 'E')
|
|
|
+ {
|
|
|
+ m_iActiveCamera = CAMERA_TYPE_OPT;
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ m_iActiveCamera = CAMERA_TYPE_ENV;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ else if (_stricmp(pszKey, SYSVAR_ACTIVETRACKINGCAMERA) == 0)
|
|
|
+ {
|
|
|
+ if (m_iCameraState == 'N')
|
|
|
+ {
|
|
|
+ if (pszValue[0] == 'E')
|
|
|
+ {
|
|
|
+ m_iActiveCamera = CAMERA_TYPE_ENV;
|
|
|
+ }
|
|
|
+ else if (pszValue[0] == 'O')
|
|
|
+ {
|
|
|
+ m_iActiveCamera = CAMERA_TYPE_OPT;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ else if (_stricmp(pszKey, SYSVAR_CALLTYPE) == 0)
|
|
|
+ {
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("sys calltype from: %c to %c", pszOldValue[0], pszValue[0]);
|
|
|
+ if(pszValue[0] == CALLTYPE_NORMAL)
|
|
|
+ {
|
|
|
+ m_nSysCallType = 0;
|
|
|
+ }
|
|
|
+ else if(pszValue[0] == CALLTYPE_MOBILE)
|
|
|
+ {
|
|
|
+ m_nSysCallType = 1;
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ m_nSysCallType = -1;
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+void CSalesRecorderEntity::OnLog( const CAutoArray<CUUID> &SubIDs, const CUUID nLogID,const LogTypeEnum eLogType, const SeverityLevelEnum eLevel, const DWORD dwSysError,const DWORD dwUserCode,const DWORD dwEntityInstanceID, const WORD wEntityDevelID, const CAutoArray<DWORD> &Param, const char *pszEntityName, const char *pszModuleName,const char *pszMessage, const linkContext &pLinkInfo)
|
|
|
+{
|
|
|
+ // 响应客户经理销售录像相关的事件
|
|
|
+ switch (dwUserCode)
|
|
|
+ {
|
|
|
+ case LOG_EVT_UI_RETURNMENU:
|
|
|
+ HandleReturnMenu();
|
|
|
+ break;
|
|
|
+
|
|
|
+ case LOG_EVT_SALESRECORD_ENTITY_EXCEPTION:
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("handle sales record entity exception, and message is %s.", pszMessage);
|
|
|
+ HandleSalesRecordEntityException(pszMessage);
|
|
|
+ break;
|
|
|
+
|
|
|
+ default:
|
|
|
+ break;
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+void CSalesRecorderEntity::StartPhone2PadRecord(const int fps, const char* wmvfilename, int videoquality, int audioOutBitRate, SubtitleParam* subtitleParam, BOOL bWholeSection, BOOL bSessionManage, eRvcRecordType eRecordType)
|
|
|
+{
|
|
|
+ bool bRet = false;
|
|
|
+
|
|
|
+ if ((ePadtype == m_eDeviceType) || (eMobilePadType == m_eDeviceType) || (eDesk1SType == m_eDeviceType) || (eDesk2SIntegratedType == m_eDeviceType))
|
|
|
+ {
|
|
|
+ //在线双录，录像统一使用前置摄像头, pad 版增加远端视频队列
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("m_pRecorder local video is REC_COMMON_VIDEO_ENV_SHM_RTP_QUEUE.");
|
|
|
+ m_pRecorder = new Clibvideorecord(&bRet, this, REC_COMMON_AUDIO_SALESOL_SHM_QUEUE, REC_COMMON_VIDEO_ENV_SHM_RTP_QUEUE,
|
|
|
+ NULL, REC_COMMON_AUDIO_SALES_SHM_QUEUE, REC_COMMON_VIDEO_REMOTE_SHM_RTP_QUEUE, REC_COMMON_REMOTEAUDIO_SHM_QUEUE);
|
|
|
+ }
|
|
|
+ else if (eDesk2SType == m_eDeviceType)
|
|
|
+ {
|
|
|
+ m_pRecorder = new Clibvideorecord(&bRet, this, REC_COMMON_AUDIO_SALESOL_SHM_QUEUE, REC_COMMON_VIDEO_SALES_EWS_SHM_RTP_QUEUE,
|
|
|
+ NULL, REC_COMMON_AUDIO_SALES_SHM_QUEUE, REC_COMMON_VIDEO_REMOTE_SHM_RTP_QUEUE, REC_COMMON_REMOTEAUDIO_SHM_QUEUE);
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ // == 2
|
|
|
+ m_pRecorder = new Clibvideorecord(&bRet, this, REC_COMMON_AUDIO_SHM_QUEUE, REC_COMMON_VIDEO_ENV_SHM_RTP_QUEUE,
|
|
|
+ REC_COMMON_VIDEO_OPT_SHM_RTP_QUEUE, REC_COMMON_AUDIO_SALES_SHM_QUEUE);
|
|
|
+ }
|
|
|
+
|
|
|
+ Rvc_RecordAudioParam_t tAudioParams;
|
|
|
+ tAudioParams.eRecordType = ePhone2Pad;
|
|
|
+ tAudioParams.eOutPutType = m_eAudioOutQuality;
|
|
|
+ tAudioParams.bIsNsOn = m_bIsAudioNsOn;
|
|
|
+ tAudioParams.iNsPolicy = m_iAudioNsPolicy;
|
|
|
+ tAudioParams.iAudioOutBitRate = 8;
|
|
|
+ tAudioParams.bIsTransOn = false;
|
|
|
+ tAudioParams.iAudioChannels = 1;
|
|
|
+
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("init lib wmv record success! and record type is %s and output audio quality is %s, audio noise suppression flag is %s. noise suppression policy is %d, video format is %s.", record_type_table[eRecordType], audio_quality_type_table[m_eAudioOutQuality], tAudioParams.bIsNsOn ? "true" : "false", tAudioParams.iNsPolicy, m_eRecordType == eMP4 ? RECORD_MP4_SUFFIX : RECORD_WMV_SUFFIX);
|
|
|
+ if (m_pRecorder->StartVideoRecord(fps, videoquality, m_eRecordType, &tAudioParams, subtitleParam, bWholeSection, FALSE, (LPCSTR)m_TempDir,
|
|
|
+ m_TempDir.GetLength(), wmvfilename, strlen(wmvfilename)))
|
|
|
+ {
|
|
|
+ m_bStarted = TRUE;
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+bool CSalesRecorderEntity::GetStandardQualityOnSiteSalesRecorder(const eRvcRecordType eRecordType)
|
|
|
+{
|
|
|
+ bool bRet = false;
|
|
|
+
|
|
|
+ if ((ePadtype == m_eDeviceType) || (eMobilePadType == m_eDeviceType) || eDesk2SType == m_eDeviceType)
|
|
|
+ {
|
|
|
+ if (ePad2Agent != eRecordType) {
|
|
|
+ m_pRecorder = new Clibvideorecord(&bRet, this, REC_COMMON_AUDIO_SALESOL_SHM_QUEUE, REC_COMMON_VIDEO_ENV_SHM_RTP_QUEUE,
|
|
|
+ NULL, REC_COMMON_AUDIO_SALES_SHM_QUEUE);
|
|
|
+ }
|
|
|
+ else{
|
|
|
+ m_pRecorder = new Clibvideorecord(&bRet, this, REC_COMMON_AUDIO_SALESOL_SHM_QUEUE, REC_COMMON_VIDEO_ENV_SHM_RTP_QUEUE,
|
|
|
+ NULL, REC_COMMON_AUDIO_SALES_SHM_QUEUE, REC_COMMON_VIDEO_REMOTE_SHM_RTP_QUEUE, REC_COMMON_REMOTEAUDIO_SHM_QUEUE);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ else if(eDesk1SType == m_eDeviceType || eDesk2SIntegratedType == m_eDeviceType)
|
|
|
+ {
|
|
|
+ if (ePad2Agent != eRecordType) {
|
|
|
+ m_pRecorder = new Clibvideorecord(&bRet, this, REC_COMMON_AUDIO_SALESOL_SHM_QUEUE, REC_COMMON_VIDEO_ENV_SHM_RTP_QUEUE,
|
|
|
+ NULL, REC_COMMON_AUDIO_SALES_SHM_QUEUE);
|
|
|
+ }
|
|
|
+ else {
|
|
|
+ m_pRecorder = new Clibvideorecord(&bRet, this, REC_COMMON_AUDIO_SALESOL_SHM_QUEUE, REC_COMMON_VIDEO_ENV_SHM_RTP_QUEUE,
|
|
|
+ NULL, REC_COMMON_AUDIO_SALES_SHM_QUEUE, REC_COMMON_VIDEO_REMOTE_SHM_RTP_QUEUE, REC_COMMON_REMOTEAUDIO_SHM_QUEUE);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ if (eStand2Agent != eRecordType){
|
|
|
+ m_pRecorder = new Clibvideorecord(&bRet, this, REC_COMMON_AUDIO_SHM_QUEUE, REC_COMMON_VIDEO_ENV_SHM_RTP_QUEUE,
|
|
|
+ REC_COMMON_VIDEO_OPT_SHM_RTP_QUEUE, REC_COMMON_AUDIO_SALES_SHM_QUEUE);
|
|
|
+ }
|
|
|
+ else{
|
|
|
+ m_pRecorder = new Clibvideorecord(&bRet, this, REC_COMMON_AUDIO_SHM_QUEUE, REC_COMMON_VIDEO_ENV_SHM_SNAPSHOT_QUEUE,
|
|
|
+ REC_COMMON_VIDEO_OPT_SHM_SNAPSHOT_QUEUE, REC_COMMON_AUDIO_SALES_SHM_QUEUE, REC_COMMON_VIDEO_REMOTE_SHM_RTP_QUEUE, REC_COMMON_REMOTEAUDIO_SHM_QUEUE);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return bRet;
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+bool CSalesRecorderEntity::GetHighQualityOnSiteSalesRecorder(const eRvcRecordType eRecordType)
|
|
|
+{
|
|
|
+ bool bRet = false;
|
|
|
+
|
|
|
+ if (ePadtype == m_eDeviceType || eMobilePadType == m_eDeviceType || eDesk2SType == m_eDeviceType)
|
|
|
+ {
|
|
|
+ if (ePad2Agent == eRecordType) {
|
|
|
+ m_pRecorder = new Clibvideorecord(&bRet, this, REC_COMMON_AUDIO_SALESOL_SHM_QUEUE, REC_COMMON_VIDEO_ENV_SHM_RTP_QUEUE,
|
|
|
+ NULL, REC_COMMON_AUDIO_SALES_SHM_QUEUE, REC_COMMON_VIDEO_REMOTE_SHM_RTP_QUEUE, REC_COMMON_REMOTEAUDIO_SHM_QUEUE);
|
|
|
+ }
|
|
|
+ else {
|
|
|
+ m_pRecorder = new Clibvideorecord(&bRet, this, REC_COMMON_AUDIO_SALESOL_SHM_QUEUE, REC_COMMON_VIDEO_ENV_SHM_SNAPSHOT_QUEUE,
|
|
|
+ NULL, REC_COMMON_AUDIO_SALES_SHM_QUEUE);
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ else if (eDesk1SType == m_eDeviceType || eDesk2SIntegratedType == m_eDeviceType)
|
|
|
+ {
|
|
|
+ if (ePad2Agent == eRecordType) {
|
|
|
+ m_pRecorder = new Clibvideorecord(&bRet, this, REC_COMMON_AUDIO_SALESOL_SHM_QUEUE, REC_COMMON_VIDEO_ENV_SHM_RTP_QUEUE,
|
|
|
+ NULL, REC_COMMON_AUDIO_SALES_SHM_QUEUE, REC_COMMON_VIDEO_REMOTE_SHM_RTP_QUEUE, REC_COMMON_REMOTEAUDIO_SHM_QUEUE);
|
|
|
+ }
|
|
|
+ else {
|
|
|
+ m_pRecorder = new Clibvideorecord(&bRet, this, REC_COMMON_AUDIO_SALESOL_SHM_QUEUE, REC_COMMON_VIDEO_ENV_SHM_SNAPSHOT_QUEUE,
|
|
|
+ NULL, REC_COMMON_AUDIO_SALES_SHM_QUEUE);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ if (eStand2Agent != eRecordType){
|
|
|
+ m_pRecorder = new Clibvideorecord(&bRet, this, REC_COMMON_AUDIO_SHM_QUEUE, REC_COMMON_VIDEO_ENV_SHM_SNAPSHOT_QUEUE,
|
|
|
+ REC_COMMON_VIDEO_OPT_SHM_SNAPSHOT_QUEUE, REC_COMMON_AUDIO_SALES_SHM_QUEUE);
|
|
|
+ }
|
|
|
+ else{
|
|
|
+ m_pRecorder = new Clibvideorecord(&bRet, this, REC_COMMON_AUDIO_SHM_QUEUE, REC_COMMON_VIDEO_ENV_SHM_SNAPSHOT_QUEUE,
|
|
|
+ REC_COMMON_VIDEO_OPT_SHM_SNAPSHOT_QUEUE, REC_COMMON_AUDIO_SALES_SHM_QUEUE, REC_COMMON_VIDEO_REMOTE_SHM_RTP_QUEUE, REC_COMMON_REMOTEAUDIO_SHM_QUEUE);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return bRet;
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+void CSalesRecorderEntity::StartOnSiteSalesRecord(const int fps, const char* wmvfilename, int videoquality, int audioOutBitRate, SubtitleParam* subtitleParam, BOOL bWholeSection, BOOL bSessionManage, eRvcRecordType eRecordType)
|
|
|
+{
|
|
|
+ bool bRet = false;
|
|
|
+ if (m_bApplyHighQuality)
|
|
|
+ {
|
|
|
+ bRet = GetHighQualityOnSiteSalesRecorder(eRecordType);
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ bRet = GetStandardQualityOnSiteSalesRecorder(eRecordType);
|
|
|
+ }
|
|
|
+
|
|
|
+ if (false == bRet){
|
|
|
+ DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("get onsite sales recorder failed.");
|
|
|
+ return;
|
|
|
+ }
|
|
|
+
|
|
|
+ Rvc_RecordAudioParam_t tAudioParams;
|
|
|
+ tAudioParams.eRecordType = eRecordType;
|
|
|
+ tAudioParams.eOutPutType = m_eAudioOutQuality;
|
|
|
+ tAudioParams.bIsNsOn = m_bIsAudioNsOn;
|
|
|
+ tAudioParams.iNsPolicy = m_iAudioNsPolicy;
|
|
|
+ tAudioParams.iAudioOutBitRate = audioOutBitRate;
|
|
|
+ tAudioParams.bIsTransOn = false;
|
|
|
+ tAudioParams.iAudioChannels = m_iAudioChannels;
|
|
|
+
|
|
|
+ if (eStand2Agent == eRecordType || ePad2Agent == eRecordType) {
|
|
|
+ tAudioParams.eOutPutType = eLowDefinition;
|
|
|
+ tAudioParams.bIsNsOn = false;
|
|
|
+ }
|
|
|
+
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("init record lib success! and record type is %s and output audio quality is %s, audio noise suppression flag is %s. noise suppression policy is %d, video format is %s.", record_type_table[eRecordType], audio_quality_type_table[m_eAudioOutQuality], tAudioParams.bIsNsOn ? "true" : "false", tAudioParams.iNsPolicy, m_eRecordType == eMP4 ? RECORD_MP4_SUFFIX : RECORD_WMV_SUFFIX);
|
|
|
+ if (m_pRecorder->StartVideoRecord(fps, videoquality, m_eRecordType, &tAudioParams, subtitleParam, bWholeSection, FALSE, (LPCSTR)m_TempDir,
|
|
|
+ m_TempDir.GetLength(), wmvfilename, strlen(wmvfilename)))
|
|
|
+ {
|
|
|
+ m_bStarted = TRUE;
|
|
|
+ }
|
|
|
+ else {
|
|
|
+ DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Start WmvRecord failed!");
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+void CSalesRecorderEntity::StartRecord(const char *wmvfilename, int videoquality, int audioOutBitRate, SubtitleParam *subtitleParam /* = NULL */, BOOL bWholeSection /* = FALSE */, BOOL bSessionManage /* = FALSE */, eRvcRecordType eRecordType /* = eSingleSide */)
|
|
|
+{
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("wmvfilename = %s", wmvfilename);
|
|
|
+ //Dbg("strPath = %s", (LPCSTR)m_TempDir);
|
|
|
+ int fps = 5;
|
|
|
+ //是否需要录制双向视频和音频
|
|
|
+ if(m_nSysCallType == 1)
|
|
|
+ {
|
|
|
+ StartPhone2PadRecord(fps, wmvfilename, videoquality, audioOutBitRate, subtitleParam, bWholeSection, bSessionManage, eRecordType);
|
|
|
+ }
|
|
|
+ // 现场销售录音录像
|
|
|
+ else
|
|
|
+ {
|
|
|
+ StartOnSiteSalesRecord(fps, wmvfilename, videoquality, audioOutBitRate, subtitleParam, bWholeSection, bSessionManage, eRecordType);
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+ErrorCodeEnum CSalesRecorderEntity::StopRecord()
|
|
|
+{
|
|
|
+ ErrorCodeEnum eCode = Error_Succeed;
|
|
|
+ if (m_bStarted) {
|
|
|
+ m_pRecorder->StopVideoRecord();
|
|
|
+ delete m_pRecorder;
|
|
|
+ m_pRecorder = NULL;
|
|
|
+ m_bStarted = FALSE;
|
|
|
+ }
|
|
|
+ //else{
|
|
|
+ // eCode = Error_InvalidState;
|
|
|
+ //}
|
|
|
+
|
|
|
+ return eCode;
|
|
|
+}
|
|
|
+
|
|
|
+ErrorCodeEnum CSalesRecorderEntity::ShowVideo( const char *wmvfilename )
|
|
|
+{
|
|
|
+ ErrorCodeEnum ErrorCode = Error_Succeed;
|
|
|
+
|
|
|
+ return ErrorCode;
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+ErrorCodeEnum CSalesRecorderEntity::PlaySalesRecordVideo( const char *wmvfilename, int iWndX, int iWndY, int iWndWidth, int iWndHeight)
|
|
|
+{
|
|
|
+ ErrorCodeEnum ErrorCode = Error_Succeed;
|
|
|
+
|
|
|
+ return ErrorCode;
|
|
|
+}
|
|
|
+
|
|
|
+void CSalesRecorderEntity::DeleteAllVideo( const char *wmvfilename )
|
|
|
+{
|
|
|
+ if(!m_bStarted)
|
|
|
+ {
|
|
|
+ CSimpleStringA strPath;
|
|
|
+ ErrorCodeEnum Error = GetFunction()->GetPath("Temp", strPath);
|
|
|
+ if (Error == Error_Succeed) {
|
|
|
+ if (strPath.GetLength() > 0 && strPath[strPath.GetLength()-1] != '\\') {
|
|
|
+ strPath += "\\";
|
|
|
+ }
|
|
|
+ ULONGLONG uVideoCount = 0;
|
|
|
+ // 删除客户经理录像 edit by ly 2018/03/05
|
|
|
+ CSimpleStringA strFindFileName = CSimpleStringA::Format("S_%s*.%s", wmvfilename, m_eRecordType == eMP4 ? RECORD_MP4_SUFFIX : RECORD_WMV_SUFFIX);
|
|
|
+ BOOL bRet = FindMatchedFile((LPCSTR)strPath, (LPCSTR)strFindFileName, uVideoCount);
|
|
|
+ if(bRet)
|
|
|
+ {
|
|
|
+ strFindFileName = strFindFileName.SubString(0,strFindFileName.GetLength()-5);
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("succeed to get sales record count while delete video!");
|
|
|
+ CSimpleStringA fileName;
|
|
|
+ BOOL bDeleteSucc = TRUE;
|
|
|
+ for(int i = 0; i != uVideoCount; ++i)
|
|
|
+ {
|
|
|
+ fileName = CSimpleStringA::Format("%s%s_%d.%s", (LPCSTR)strPath, (LPCSTR)strFindFileName, i, m_eRecordType == eMP4 ? RECORD_MP4_SUFFIX : RECORD_WMV_SUFFIX);
|
|
|
+
|
|
|
+ bRet = DeleteFile((LPCSTR)fileName);
|
|
|
+ if(!bRet) {
|
|
|
+ bDeleteSucc = FALSE;
|
|
|
+ DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Error Code %lu while delete %s ", GetLastError(), (LPCSTR)fileName);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (bDeleteSucc) {
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("succeed to delete sales video!");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("sales videos not exist or have been deleted!");
|
|
|
+ }
|
|
|
+
|
|
|
+ // 删除见证录像
|
|
|
+ uVideoCount = 0;
|
|
|
+ strFindFileName = CSimpleStringA::Format("W_%s*.%s", wmvfilename, m_eRecordType == eMP4 ? RECORD_MP4_SUFFIX : RECORD_WMV_SUFFIX);
|
|
|
+ bRet = FindMatchedFile((LPCSTR)strPath, (LPCSTR)strFindFileName, uVideoCount);
|
|
|
+ if(bRet)
|
|
|
+ {
|
|
|
+ strFindFileName = strFindFileName.SubString(0,strFindFileName.GetLength()-5);
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("succeed to get witness record count while delete video!");
|
|
|
+ CSimpleStringA fileName;
|
|
|
+ BOOL bDeleteSucc = TRUE;
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("uVideoCount=%d", uVideoCount);
|
|
|
+ for(int i = 0; i != uVideoCount; ++i)
|
|
|
+ {
|
|
|
+ fileName = CSimpleStringA::Format("%s%s_%d.%s", (LPCSTR)strPath, (LPCSTR)strFindFileName, i, m_eRecordType == eMP4 ? RECORD_MP4_SUFFIX : RECORD_WMV_SUFFIX);
|
|
|
+
|
|
|
+ bRet = DeleteFile((LPCSTR)fileName);
|
|
|
+ if(!bRet) {
|
|
|
+ bDeleteSucc = FALSE;
|
|
|
+ DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Error Code %lu while delete %s ", GetLastError(), (LPCSTR)fileName);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (bDeleteSucc) {
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("succeed to delete witness video!");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("witness videos not exist or have been deleted!");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+ErrorCodeEnum CSalesRecorderEntity::DeleteVideo( const char *wmvfilename )
|
|
|
+{
|
|
|
+ ErrorCodeEnum ErrorCode = Error_Succeed;
|
|
|
+ if(!m_bStarted)
|
|
|
+ {
|
|
|
+ CSimpleStringA strPath;
|
|
|
+ ErrorCodeEnum Error = GetFunction()->GetPath("Temp", strPath);
|
|
|
+ if (Error == Error_Succeed) {
|
|
|
+ if (strPath.GetLength() > 0 && strPath[strPath.GetLength()-1] != '\\') {
|
|
|
+ strPath += "\\";
|
|
|
+ }
|
|
|
+ CSimpleStringA strFindFileName = CSimpleStringA::Format("%s*.%s", wmvfilename, m_eRecordType == eMP4 ? RECORD_MP4_SUFFIX : RECORD_WMV_SUFFIX);
|
|
|
+ ULONGLONG uVideoCount = 0;
|
|
|
+ BOOL bRet = FindMatchedFile((LPCSTR)strPath, (LPCTSTR)strFindFileName, uVideoCount);
|
|
|
+ if(bRet)
|
|
|
+ {
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("succeed to get record count while delete video!");
|
|
|
+ CSimpleStringA fileName;
|
|
|
+ BOOL bDeleteSucc = TRUE;
|
|
|
+ for(int i = 0; i != uVideoCount; ++i)
|
|
|
+ {
|
|
|
+ fileName = CSimpleStringA::Format("%s%s_%d.%s", (LPCSTR)strPath, wmvfilename, i, m_eRecordType == eMP4 ? RECORD_MP4_SUFFIX : RECORD_WMV_SUFFIX);
|
|
|
+
|
|
|
+ bRet = DeleteFile((LPCSTR)fileName);
|
|
|
+ if(!bRet) {
|
|
|
+ bDeleteSucc = FALSE;
|
|
|
+ DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Error Code %lu while delete %s ", GetLastError(), (LPCSTR)fileName);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (bDeleteSucc) {
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("succeed to delete videos!");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ ErrorCode = Error_NotExist;
|
|
|
+ DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("[DeleteVideo] videos not exist or have been deleted!");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ else {
|
|
|
+ ErrorCode = Error_NotImpl;
|
|
|
+ }
|
|
|
+
|
|
|
+ return ErrorCode;
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+/*
|
|
|
+SaveVideo包含两步，找到录像和移动录像
|
|
|
+Error_Succeed 提交上传成功
|
|
|
+Error_NotExist not exist
|
|
|
+Error_NotImpl 方法执行失败
|
|
|
+*/
|
|
|
+
|
|
|
+ErrorCodeEnum CSalesRecorderEntity::SaveVideo( const char *wmvfilename)
|
|
|
+{
|
|
|
+ ErrorCodeEnum ErrorCode = Error_Succeed;
|
|
|
+
|
|
|
+ if(!m_bStarted)
|
|
|
+ {
|
|
|
+ CSimpleStringA sourPath;
|
|
|
+ ErrorCodeEnum Error = GetFunction()->GetPath("Temp", sourPath);
|
|
|
+ if(Error == Error_Succeed)
|
|
|
+ {
|
|
|
+ if (sourPath.GetLength() > 0 && sourPath[sourPath.GetLength()-1] != '\\') {
|
|
|
+ sourPath += "\\";
|
|
|
+ }
|
|
|
+ ULONGLONG uVideoCount = 0;
|
|
|
+ CSimpleStringA strFindFileName = CSimpleStringA::Format("S_%s*.%s", wmvfilename, m_eRecordType == eMP4 ? RECORD_MP4_SUFFIX : RECORD_WMV_SUFFIX);
|
|
|
+ BOOL bRet = FindMatchedFile((LPCSTR)sourPath, (LPCSTR)strFindFileName, uVideoCount);
|
|
|
+ if(bRet)
|
|
|
+ {
|
|
|
+ strFindFileName = strFindFileName.SubString(0,strFindFileName.GetLength()-5);
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("succeed to get sales record count while save video!");
|
|
|
+ CSimpleStringA destPath;
|
|
|
+ Error = GetFunction()->GetPath("UploadVideo", destPath);
|
|
|
+ if(Error == Error_Succeed)
|
|
|
+ {
|
|
|
+ if (destPath.GetLength() > 0 && destPath[destPath.GetLength()-1] != '\\') {
|
|
|
+ destPath += "\\";
|
|
|
+ }
|
|
|
+ CSimpleStringA sourFileName, destFileName;
|
|
|
+ BOOL bMoveSucc = TRUE;
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("strFindFileName=%s", (LPCSTR)strFindFileName);
|
|
|
+ for(int i = 0; i != uVideoCount; ++i)
|
|
|
+ {
|
|
|
+ sourFileName = CSimpleStringA::Format("%s%s_%d.%s", (LPCSTR)sourPath, (LPCSTR)strFindFileName, i, m_eRecordType == eMP4 ? RECORD_MP4_SUFFIX : RECORD_WMV_SUFFIX);
|
|
|
+ destFileName = CSimpleStringA::Format("%s%s_%d.%s", (LPCSTR)destPath, (LPCSTR)strFindFileName, i, m_eRecordType == eMP4 ? RECORD_MP4_SUFFIX : RECORD_WMV_SUFFIX);
|
|
|
+ unsigned long ufilesize = GetFileSize(sourFileName.GetData());
|
|
|
+ char strtext[MAX_PATH] = {0};
|
|
|
+ _snprintf(strtext, MAX_PATH, "%s file size is %u byte.", (LPCSTR)sourFileName, ufilesize);
|
|
|
+ LogWarn(Severity_Low, Error_Debug, LOG_EVT_RECORD_FILESIZE, strtext);
|
|
|
+ bRet = MoveFile((LPCSTR)sourFileName, (LPCSTR)destFileName);
|
|
|
+ if(!bRet) {
|
|
|
+ bMoveSucc = FALSE;
|
|
|
+ ErrorCode = Error_NotImpl;
|
|
|
+ char strinfo[MAX_PATH] = {0};
|
|
|
+ _snprintf(strinfo, MAX_PATH, "Error Code %lu while move %s.", GetLastError(), (LPCSTR)sourFileName);
|
|
|
+ LogWarn(Severity_Middle, Error_Debug, LOG_EVT_RECORD_SAVED_FAILED, strinfo);
|
|
|
+ if (183 == GetLastError()){
|
|
|
+ ErrorCode = Error_InvalidState;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ if (ufilesize > RVC_MIN_FILESIZE){
|
|
|
+
|
|
|
+ }
|
|
|
+ else{
|
|
|
+ char strmsg[MAX_PATH] = {0};
|
|
|
+ _snprintf(strmsg, MAX_PATH, "%s file size is %u.", (LPCSTR)sourFileName, ufilesize);
|
|
|
+ LogWarn(Severity_Middle, Error_Debug, LOG_EVT_RECORD_INVALID_FILE, strmsg);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (bMoveSucc) {
|
|
|
+ char strmsg[MAX_PATH] = {0};
|
|
|
+ _snprintf(strmsg, MAX_PATH, "succeed to save sales video, move it from %s to %s.", sourFileName.GetData(), destFileName.GetData());
|
|
|
+ LogWarn(Severity_Low, Error_Debug, LOG_EVT_RECORD_SAVED_SUCCESS, strmsg);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ else{
|
|
|
+ LogWarn(Severity_Middle, Error_Debug, LOG_EVT_RECORD_SAVED_FAILED, "sales videos not exist or have been deleted");
|
|
|
+ ErrorCode = Error_NotExist;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ else{
|
|
|
+ ErrorCode = Error_InvalidState;
|
|
|
+ }
|
|
|
+
|
|
|
+ return ErrorCode;
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+CSimpleStringA CSalesRecorderEntity::GetTerminalStage()
|
|
|
+{
|
|
|
+ CSmartPointer<IEntityFunction> Func = GetFunction();
|
|
|
+ CSimpleStringA strValue = "";
|
|
|
+ Func->GetSysVar("TerminalStage", strValue);
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("TerminalStage:%s", (LPCTSTR)strValue);
|
|
|
+ return strValue;
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+ErrorCodeEnum CSalesRecorderEntity::StopRecordVideo()
|
|
|
+{
|
|
|
+ auto rc = Error_Succeed;
|
|
|
+
|
|
|
+ auto pUIClient = new UIService_ClientBase(this);
|
|
|
+
|
|
|
+ if(pUIClient->Connect() != Error_Succeed)
|
|
|
+ {
|
|
|
+ pUIClient->SafeDelete();
|
|
|
+ pUIClient = NULL;
|
|
|
+ rc = Error_DevConnFailed;
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("UIClient connected success!");
|
|
|
+ UIService_StopRecordVideo_Req req;
|
|
|
+ UIService_StopRecordVideo_Ans ans;
|
|
|
+ rc = (*pUIClient)(EntityResource::getLink().upgradeLink())->StopRecordVideo(req, ans, 5000);
|
|
|
+ if(rc != Error_Succeed)
|
|
|
+ {
|
|
|
+ DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Stop record video failed return 0x%08x", rc);
|
|
|
+ }
|
|
|
+
|
|
|
+ pUIClient->GetFunction()->CloseSession();
|
|
|
+ pUIClient->SafeDelete();
|
|
|
+ pUIClient = NULL;
|
|
|
+ }
|
|
|
+
|
|
|
+ return rc;
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+ErrorCodeEnum CSalesRecorderEntity::HandleStartRecord(const char *pszMessage, const bool bRemoteRecord)
|
|
|
+{
|
|
|
+ ErrorCodeEnum Error = Error_Succeed;
|
|
|
+ eRvcRecordType eRecordType = eSingleSide;
|
|
|
+ if (NULL == pszMessage){
|
|
|
+ return Error_Param;
|
|
|
+ }
|
|
|
+
|
|
|
+ size_t ulen = strlen(pszMessage);
|
|
|
+ char *tmp = new char[ulen+1];
|
|
|
+
|
|
|
+ strncpy_s(tmp, ulen+1, pszMessage, ulen);
|
|
|
+
|
|
|
+ char *result[16] = {0};
|
|
|
+ //CStringSplit(tmp, result, "@");
|
|
|
+ // 解决中文stringsplit偶现乱码的问题 edit by ly@2018/07/04
|
|
|
+ auto arr1 = CSimpleStringA2W(tmp).Split('@');
|
|
|
+ auto arr2 = CAutoArray<CSimpleStringA>(arr1.GetCount());
|
|
|
+ for (int i = 0; i < arr1.GetCount(); ++i)
|
|
|
+ {
|
|
|
+ arr2[i] = CSimpleStringW2A(arr1[i]);
|
|
|
+ result[i] = const_cast<LPSTR>(arr2[i].GetData());
|
|
|
+ }
|
|
|
+
|
|
|
+ sprintf(m_SalesVideoName, "%s", result[4]);//录像名：录像类型标志_录像流水号（如S_C13213EF）
|
|
|
+ RecordSubTitle subTitle;
|
|
|
+ ZeroMemory(&subTitle,sizeof(RecordSubTitle));
|
|
|
+ CSimpleStringA strCardNo = DecryptString(result[5]);
|
|
|
+ if (sizeof(subTitle.CustCardNo) > strCardNo.GetLength()){
|
|
|
+ strcpy_s(subTitle.CustCardNo, strCardNo.GetData());
|
|
|
+ }
|
|
|
+ else{
|
|
|
+ DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Invalid CustCardNo.");
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ char *pStr = result[6];
|
|
|
+ CSimpleStringW szCustName = CSimpleStringA2W(pStr);
|
|
|
+ if (szCustName.GetLength() <= 4) {
|
|
|
+ strcpy(subTitle.CustName, pStr);
|
|
|
+ }
|
|
|
+ else {
|
|
|
+ CSimpleStringW aa = szCustName.SubString(0,4);
|
|
|
+ sprintf(subTitle.CustName,"%s...",(LPCTSTR)CSimpleStringW2A(aa));
|
|
|
+ }
|
|
|
+
|
|
|
+ // 解决产品代码、产品名称过长，画面上显示不下的问题
|
|
|
+ // 朝朝赢和招财赢支持双向录像
|
|
|
+ pStr = result[7];
|
|
|
+ int nProductCodeLen = strlen(pStr);
|
|
|
+
|
|
|
+ if (nProductCodeLen <= 10) {
|
|
|
+ strcpy(subTitle.ProductCode, pStr);
|
|
|
+ }
|
|
|
+ else {
|
|
|
+ char aa[5]={0},bb[5]={0};
|
|
|
+ strncpy(aa, pStr, 4);
|
|
|
+ strncpy(bb, pStr+nProductCodeLen-4, 4);
|
|
|
+ sprintf(subTitle.ProductCode,"%s...%s",aa,bb);
|
|
|
+ }
|
|
|
+
|
|
|
+ pStr = result[8];
|
|
|
+ CSimpleStringW szProductName = CSimpleStringA2W(pStr);
|
|
|
+ if (szProductName.GetLength() <= 5) {
|
|
|
+ strcpy(subTitle.ProductName, pStr);
|
|
|
+ }
|
|
|
+ else {
|
|
|
+ CSimpleStringW aa = szProductName.SubString(0,3);
|
|
|
+ CSimpleStringW bb = szProductName.SubString(szProductName.GetLength()-2,2);
|
|
|
+ sprintf(subTitle.ProductName,"%s...%s",(LPCTSTR)CSimpleStringW2A(aa),(LPCTSTR)CSimpleStringW2A(bb));
|
|
|
+ }
|
|
|
+
|
|
|
+ if (result[9]) {
|
|
|
+ strcpy(subTitle.SapID, result[9]);
|
|
|
+ } else {
|
|
|
+ subTitle.SapID[0] = '\0';
|
|
|
+ }
|
|
|
+
|
|
|
+ if (result[10]) {
|
|
|
+ pStr = result[10];
|
|
|
+ CSimpleStringW szCustManagerName = CSimpleStringA2W(pStr);
|
|
|
+ if (szCustManagerName.GetLength() <= 4) {
|
|
|
+ strcpy(subTitle.CustManagerName, result[10]);
|
|
|
+ }
|
|
|
+ else {
|
|
|
+ CSimpleStringW aa = szCustManagerName.SubString(0,4);
|
|
|
+ sprintf(subTitle.CustManagerName,"%s...",(LPCTSTR)CSimpleStringW2A(aa));
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ subTitle.CustManagerName[0] = '\0';
|
|
|
+ }
|
|
|
+
|
|
|
+ delete[] tmp;
|
|
|
+ tmp = NULL;
|
|
|
+
|
|
|
+ SubtitleParam subtitleParam;
|
|
|
+ ZeroMemory(&subtitleParam,sizeof(SubtitleParam));
|
|
|
+ subtitleParam.bSubtitle = TRUE;
|
|
|
+ subtitleParam.bSubtitleSection = TRUE;
|
|
|
+ subtitleParam.topSubtitleData[0] = '\0';
|
|
|
+ if (strlen(subTitle.SapID)>0&&strlen(subTitle.CustManagerName)>0){
|
|
|
+ sprintf(subtitleParam.bottomSubtitleData1, "%s %s %s", subTitle.CustCardNo, subTitle.CustName, subTitle.ProductCode);
|
|
|
+ sprintf(subtitleParam.bottomSubtitleData2, "%s %s %s", subTitle.ProductName, subTitle.SapID, subTitle.CustManagerName);
|
|
|
+ }
|
|
|
+ else{
|
|
|
+ sprintf(subtitleParam.bottomSubtitleData1, "%s %s", subTitle.CustCardNo, subTitle.CustName);
|
|
|
+ sprintf(subtitleParam.bottomSubtitleData2, "%s %s", subTitle.ProductCode, subTitle.ProductName);
|
|
|
+ }
|
|
|
+
|
|
|
+ int i_audio_out_bitrate = m_audio_out_bitrate;
|
|
|
+
|
|
|
+ if (bRemoteRecord)
|
|
|
+ {
|
|
|
+ if (m_eDeviceType == eStand2sType) { //如果是大机
|
|
|
+ eRecordType = eStand2Agent; //可视柜台大机的双向录像
|
|
|
+ }
|
|
|
+ else{
|
|
|
+ eRecordType = ePad2Agent; //可视柜台pad的双向录像
|
|
|
+ }
|
|
|
+
|
|
|
+ if(256 == m_audio_out_bitrate){
|
|
|
+ i_audio_out_bitrate = 128;
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("change remote record audio out bitrate to %d.", i_audio_out_bitrate);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ StartRecord(m_SalesVideoName, 90, i_audio_out_bitrate, &subtitleParam, m_bWholeSection, FALSE, eRecordType);
|
|
|
+
|
|
|
+ char strmsg[MAX_PATH] = {0};
|
|
|
+ _snprintf(strmsg, MAX_PATH, "start remote record %s.", m_SalesVideoName);
|
|
|
+ LogWarn(Severity_Low, Error_Debug, LOG_EVT_START_REMOTERECORD, strmsg);
|
|
|
+
|
|
|
+ return Error;
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+ErrorCodeEnum CSalesRecorderEntity::HandleStopRecord(const char *pszMessage)
|
|
|
+{
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("stop record video name is %s!", m_SalesVideoName);
|
|
|
+
|
|
|
+ ErrorCodeEnum ErrorCode = StopRecord();
|
|
|
+
|
|
|
+ return ErrorCode;
|
|
|
+}
|
|
|
+
|
|
|
+ErrorCodeEnum CSalesRecorderEntity::HandleSetAudioTransmissionFlag(bool bFlag)
|
|
|
+{
|
|
|
+ ErrorCodeEnum ErrorCode = Error_Succeed;
|
|
|
+ return ErrorCode;
|
|
|
+}
|
|
|
+
|
|
|
+ErrorCodeEnum CSalesRecorderEntity::HandleDisplayVideo()
|
|
|
+{
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("play record file name is %s!", m_SalesVideoName);
|
|
|
+ ErrorCodeEnum ErrorCode = ShowVideo(m_SalesVideoName);
|
|
|
+ return ErrorCode;
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+ErrorCodeEnum CSalesRecorderEntity::HandlePlaySalesRecordVideo(int iWndX, int iWndY, int iWndWidth, int iWndHeight)
|
|
|
+{
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("play sales record video file name is %s!", m_SalesVideoName);
|
|
|
+ ErrorCodeEnum ErrorCode = PlaySalesRecordVideo(m_SalesVideoName, iWndX, iWndY, iWndWidth, iWndHeight);
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("play sales record video return code is 0x%08x.", ErrorCode);
|
|
|
+ return ErrorCode;
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+ErrorCodeEnum CSalesRecorderEntity::HandleStopShowVideo()
|
|
|
+{
|
|
|
+ // 视频播放 libwmpplayer
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("stop show video record file name is %s!", m_SalesVideoName);
|
|
|
+ ErrorCodeEnum ErrorCode = Error_Succeed;
|
|
|
+ return ErrorCode;
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ErrorCodeEnum CSalesRecorderEntity::HandleSaveVideo()
|
|
|
+{
|
|
|
+ ErrorCodeEnum ErrorCode = Error_Succeed;
|
|
|
+
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Save Record Name is %s.", m_SalesVideoName);
|
|
|
+
|
|
|
+ // 将视频从tmp移动到uploadvideo
|
|
|
+ ErrorCode = SaveVideo(m_SalesVideoName+2);
|
|
|
+
|
|
|
+ ZeroMemory(m_SalesVideoName,sizeof(m_SalesVideoName));
|
|
|
+
|
|
|
+ return ErrorCode;
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+ErrorCodeEnum CSalesRecorderEntity::HandleDeleteVideo()
|
|
|
+{
|
|
|
+ ErrorCodeEnum ErrorCode = Error_Succeed;
|
|
|
+
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Delete Record Name is %s.", m_SalesVideoName);
|
|
|
+ // 删除tmp中的视频
|
|
|
+ ErrorCode = DeleteVideo(m_SalesVideoName);
|
|
|
+
|
|
|
+ ZeroMemory(m_SalesVideoName,sizeof(m_SalesVideoName));
|
|
|
+
|
|
|
+ return ErrorCode;
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+void CSalesRecorderEntity::HandleReturnMenu()
|
|
|
+{
|
|
|
+ CSimpleStringA strValue;
|
|
|
+ GetFunction()->GetSysVar("DesktopType", strValue);
|
|
|
+ if (strValue != CSimpleStringA("U"))
|
|
|
+ {
|
|
|
+ if (m_bStarted) // 如果正在进行客户经理录像
|
|
|
+ {
|
|
|
+ // 停止录像
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("stop record and return menu!");
|
|
|
+ StopRecord();
|
|
|
+ }
|
|
|
+
|
|
|
+ // 删除tmp中的视频
|
|
|
+ if (strlen(m_SalesVideoName) > 0)
|
|
|
+ {
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("delete sales record!");
|
|
|
+ DeleteAllVideo(m_SalesVideoName+2);
|
|
|
+ }
|
|
|
+
|
|
|
+ ZeroMemory(m_SalesVideoName,sizeof(m_SalesVideoName));
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+void CSalesRecorderEntity::HandleUkeyPullout()
|
|
|
+{
|
|
|
+ if (m_SalesVideoName && strstr(m_SalesVideoName, "OFL"))
|
|
|
+ {
|
|
|
+ if (m_bStarted) // 如果正在进行客户经理录像
|
|
|
+ {
|
|
|
+ // 停止录像
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("stop record and return menu!");
|
|
|
+ StopRecord();
|
|
|
+ }
|
|
|
+
|
|
|
+ // 删除录像记录临时文件
|
|
|
+ CSimpleStringA cfn = CSimpleStringA::Format("%s%s.txt", (LPCTSTR)m_TempDir, m_SalesVideoName);
|
|
|
+ DeleteFile(cfn);
|
|
|
+
|
|
|
+ // 删除tmp中的视频
|
|
|
+ if (strlen(m_SalesVideoName) > 0)
|
|
|
+ {
|
|
|
+ DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("delete sales record!");
|
|
|
+ DeleteAllVideo(m_SalesVideoName+4);
|
|
|
+ }
|
|
|
+
|
|
|
+ ZeroMemory(m_SalesVideoName,sizeof(m_SalesVideoName));
|
|
|
+ StopRecordVideo();
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+ErrorCodeEnum CSalesRecorderEntity::HandleVideoAppendWatermark(const char* pszVideoName, const char* pszWaterMark)
|
|
|
+{
|
|
|
+ ErrorCodeEnum Error = Error_Failed;
|
|
|
+ if (NULL == pszWaterMark){
|
|
|
+ return Error_Param;
|
|
|
+ }
|
|
|
+
|
|
|
+ if (m_bStarted && (NULL != m_pRecorder)) {
|
|
|
+ if (m_pRecorder->SetRightVideoWaterMark(pszWaterMark)) {
|
|
|
+ Error = Error_Succeed;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ return Error;
|
|
|
+}
|
|
|
+
|
|
|
+ErrorCodeEnum CSalesRecorderEntity::HandleSalesRecordEntityException(const char* pszMessage)
|
|
|
+{
|
|
|
+ // 通知到业务中台
|
|
|
+ SalesRecordException evt;
|
|
|
+ evt.failedmsg = CSimpleStringA2W(pszMessage==NULL?"现场销售双录过程出现异常！":pszMessage);
|
|
|
+ SpSendBroadcast(GetFunction(), SP_MSG_OF(SalesRecordException), SP_MSG_SIG_OF(SalesRecordException), evt);
|
|
|
+ DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("[dbg] SalesRecord entity exception broadcast sent!");
|
|
|
+
|
|
|
+ //停止录像
|
|
|
+ StopRecord();
|
|
|
+
|
|
|
+ m_bNeedRestart = true;
|
|
|
+
|
|
|
+ //重启实体
|
|
|
+ RealSelfCheck();
|
|
|
+
|
|
|
+ return Error_Succeed;
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+ErrorCodeEnum CSalesRecorderEntity::RealSelfCheck()
|
|
|
+{
|
|
|
+ ErrorCodeEnum Error = Error_Succeed;
|
|
|
+ SelfChekerClient* pSelfcheckClient = new SelfChekerClient(this);
|
|
|
+ Error = pSelfcheckClient->Connect();
|
|
|
+ if (Error != Error_Succeed)
|
|
|
+ {
|
|
|
+ pSelfcheckClient->SafeDelete();
|
|
|
+ pSelfcheckClient = NULL;
|
|
|
+ DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("SelfcheckClient connect fail!");
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("SelfcheckClient connect success!");
|
|
|
+ }
|
|
|
+
|
|
|
+ if (pSelfcheckClient)
|
|
|
+ {
|
|
|
+ SelfCheckerService_RealCheck_Req req;
|
|
|
+ req.name = GetEntityName();
|
|
|
+ SelfCheckerService_RealCheck_Ans ans;
|
|
|
+ DWORD Timeout = 500;
|
|
|
+ Error = pSelfcheckClient->RealCheck(req,ans,Timeout);
|
|
|
+ if (Error!=Error_Succeed)
|
|
|
+ {
|
|
|
+ DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("RealSelfcheck fail!");
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("RealSelfcheck success!");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ LogWarn(Severity_Middle, Error_Debug, LOG_EVT_ENTITY_RESTART, "sales record entity self restart.");
|
|
|
+
|
|
|
+ return Error;
|
|
|
+}
|
|
|
+
|
|
|
+bool IsMatchedVideo(WIN32_FIND_DATA fileData)
|
|
|
+{
|
|
|
+ bool bRet = false;
|
|
|
+
|
|
|
+ if ('S' == fileData.cFileName[0] || 'W' == fileData.cFileName[0]){
|
|
|
+ SYSTEMTIME sysTime;
|
|
|
+ FileTimeToSystemTime(&fileData.ftCreationTime, &sysTime);
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("File %s create data info is %d %d %d.", fileData.cFileName, sysTime.wYear, sysTime.wMonth, sysTime.wDay);
|
|
|
+ if ((2020 == sysTime.wYear) && (sysTime.wMonth == 1)){
|
|
|
+ if (sysTime.wDay >= 3 && sysTime.wDay <= 10){
|
|
|
+ bRet = true;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ return bRet;
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+void CSalesRecorderEntity::UploadTempPathVideos()
|
|
|
+{
|
|
|
+ CSimpleStringA sourPath;
|
|
|
+ CSimpleStringA destPath;
|
|
|
+ ErrorCodeEnum Error = GetFunction()->GetPath("Temp", sourPath);
|
|
|
+ Error = GetFunction()->GetPath("UploadVideo", destPath);
|
|
|
+
|
|
|
+ if (sourPath.GetLength() > 0 && sourPath[sourPath.GetLength()-1] != SPLIT_SLASH) {
|
|
|
+ sourPath += SPLIT_SLASH_STR;
|
|
|
+ }
|
|
|
+
|
|
|
+ if (destPath.GetLength() > 0 && destPath[destPath.GetLength()-1] != SPLIT_SLASH) {
|
|
|
+ destPath += SPLIT_SLASH_STR;
|
|
|
+ }
|
|
|
+
|
|
|
+ if(Error == Error_Succeed)
|
|
|
+ {
|
|
|
+ char srcFilePath[MAX_PATH]={0};
|
|
|
+ WIN32_FIND_DATA FindFileData;
|
|
|
+ HANDLE hFind;
|
|
|
+ BOOL fFinished = FALSE;
|
|
|
+ sprintf_s(srcFilePath, MAX_PATH, "%s*.%s", sourPath, m_eRecordType == eMP4 ? RECORD_MP4_SUFFIX : RECORD_WMV_SUFFIX);
|
|
|
+
|
|
|
+ hFind = FindFirstFile(srcFilePath, &FindFileData);
|
|
|
+
|
|
|
+ if (INVALID_HANDLE_VALUE != hFind)
|
|
|
+ {
|
|
|
+ while (!fFinished)
|
|
|
+ {
|
|
|
+ if (FILE_ATTRIBUTE_DIRECTORY & FindFileData.dwFileAttributes)
|
|
|
+ {
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+
|
|
|
+ if (IsMatchedVideo(FindFileData)){
|
|
|
+ CSimpleStringA sourFileName = CSimpleStringA::Format("%s%s", (LPCSTR)sourPath, FindFileData.cFileName);
|
|
|
+ CSimpleStringA destFileName = CSimpleStringA::Format("%sBAK_%s", (LPCSTR)destPath, FindFileData.cFileName);
|
|
|
+ if(!MoveFile((LPCSTR)sourFileName, (LPCSTR)destFileName)) {
|
|
|
+ DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Error Code %lu while move %s ", GetLastError(), (LPCSTR)sourFileName);
|
|
|
+ }else{
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Move File %s success.", (LPCSTR)sourFileName);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ else{
|
|
|
+ DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("File (%s) is not matched.", FindFileData.cFileName);
|
|
|
+ }
|
|
|
+
|
|
|
+ if (!FindNextFile(hFind, &FindFileData))
|
|
|
+ {
|
|
|
+ if (GetLastError() == ERROR_NO_MORE_FILES)
|
|
|
+ {
|
|
|
+ fFinished = TRUE;
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ FindClose(hFind);
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+int CSalesRecorderEntity::GetSystemMemoryUsage()
|
|
|
+{
|
|
|
+
|
|
|
+ // Use to convert bytes to KB
|
|
|
+#define DIV 1024
|
|
|
+
|
|
|
+ MEMORYSTATUSEX statex;
|
|
|
+
|
|
|
+ statex.dwLength = sizeof (statex);
|
|
|
+
|
|
|
+ GlobalMemoryStatusEx (&statex);
|
|
|
+
|
|
|
+ return statex.dwMemoryLoad;
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+double CSalesRecorderEntity::GetSystemCpuUsage()
|
|
|
+{
|
|
|
+ double ratio = 0;
|
|
|
+#define _WIN32_WINNT 0x0601
|
|
|
+ FILETIME idleTime,kernelTime,userTime;
|
|
|
+ BOOL ret = GetSystemTimes(&idleTime,&kernelTime,&userTime);
|
|
|
+ if (ret == 0)
|
|
|
+ {
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("GetSystemCPUStatus.GetSystemTimes failed(%d).",GetLastError());
|
|
|
+ return 80.0;
|
|
|
+ }
|
|
|
+ __int64 xIdle,xKernel,xUser;
|
|
|
+ xIdle = idleTime.dwHighDateTime;
|
|
|
+ xIdle <<= 32;
|
|
|
+ xIdle |= idleTime.dwLowDateTime;
|
|
|
+ xKernel = kernelTime.dwHighDateTime;
|
|
|
+ xKernel <<= 32;
|
|
|
+ xKernel |= kernelTime.dwLowDateTime;
|
|
|
+ xUser = userTime.dwHighDateTime;
|
|
|
+ xUser <<= 32;
|
|
|
+ xUser |= userTime.dwLowDateTime;
|
|
|
+
|
|
|
+ if (m_xIdlePre != 0)
|
|
|
+ {
|
|
|
+ __int64 xI,xK,xU;
|
|
|
+ xI = xIdle - m_xIdlePre;
|
|
|
+ xK = xKernel - m_xKernelPre;
|
|
|
+ xU = xUser - m_xUserPre;
|
|
|
+
|
|
|
+ if ((xK +xU) != 0)
|
|
|
+ ratio = (xK - xI + xU) * 100 / (xK + xU);
|
|
|
+ }
|
|
|
+ m_xIdlePre = xIdle;
|
|
|
+ m_xKernelPre = xKernel;
|
|
|
+ m_xUserPre = xUser;
|
|
|
+
|
|
|
+ return ratio;
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+ErrorCodeEnum CSalesRecorderEntity::SetRecordAudioQuality(int iAudioQuality)
|
|
|
+{
|
|
|
+ ErrorCodeEnum eRet = Error_Succeed;
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("iAudioQuality == %d.", iAudioQuality);
|
|
|
+
|
|
|
+ switch (iAudioQuality)
|
|
|
+ {
|
|
|
+ case 1:
|
|
|
+ m_eAudioOutQuality = eLowDefinition;
|
|
|
+ break;
|
|
|
+ case 2:
|
|
|
+ m_eAudioOutQuality = eStandardDefinition;
|
|
|
+ break;
|
|
|
+ case 3:
|
|
|
+ m_eAudioOutQuality = eHighDefinition;
|
|
|
+ break;
|
|
|
+ case 4:
|
|
|
+ m_eAudioOutQuality = eUltraHD;
|
|
|
+ break;
|
|
|
+ default:
|
|
|
+ m_eAudioOutQuality = eUltraHD;
|
|
|
+ break;
|
|
|
+ }
|
|
|
+
|
|
|
+ return eRet;
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+ErrorCodeEnum CSalesRecorderEntity::SetRecordAudioNsPolicy(int iNsPolicy)
|
|
|
+{
|
|
|
+ ErrorCodeEnum eRet = Error_Succeed;
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("iNsPolicy == %d.", iNsPolicy);
|
|
|
+
|
|
|
+ if (1 == iNsPolicy || 3 == iNsPolicy){
|
|
|
+ m_iAudioNsPolicy = iNsPolicy;
|
|
|
+ }
|
|
|
+ else{
|
|
|
+ m_iAudioNsPolicy = 2;
|
|
|
+ }
|
|
|
+
|
|
|
+ return eRet;
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+ErrorCodeEnum CSalesRecorderEntity::SetRecordAudioChannles(int iAudioChannles)
|
|
|
+{
|
|
|
+ ErrorCodeEnum eRet = Error_Succeed;
|
|
|
+
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Get iAudioChannles == %d.", iAudioChannles);
|
|
|
+
|
|
|
+ m_iAudioChannels = 2;
|
|
|
+
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Set AudioChannles == %d.", m_iAudioChannels);
|
|
|
+
|
|
|
+ return eRet;
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+DeviceTypeEnum CSalesRecorderEntity::RvcGetDeviceType()
|
|
|
+{
|
|
|
+ DeviceTypeEnum eType = eStand2sType;
|
|
|
+ CSmartPointer<IEntityFunction> spFunction = GetFunction();
|
|
|
+ CSystemStaticInfo stStaticinfo;
|
|
|
+ spFunction->GetSystemStaticInfo(stStaticinfo);
|
|
|
+ m_terminalNo = stStaticinfo.strTerminalID;
|
|
|
+
|
|
|
+ if (stricmp(stStaticinfo.strMachineType, "RVC.PAD") == 0) {
|
|
|
+ if (stricmp(stStaticinfo.strSite, "CMB.FLB") == 0) {
|
|
|
+ eType = eMobilePadType;
|
|
|
+ }
|
|
|
+ else {
|
|
|
+ eType = ePadtype;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ else if (stricmp(stStaticinfo.strMachineType, "RVC.Desk2S") == 0) {
|
|
|
+ eType = eDesk2SType;
|
|
|
+ WORD nMajor = stStaticinfo.MachineVersion.GetMajor();
|
|
|
+ WORD nMinor = stStaticinfo.MachineVersion.GetMinor();
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("MachineVersion is %d.%d", nMajor, nMinor);
|
|
|
+ if (2 == nMajor) {
|
|
|
+ eType = eDesk2SIntegratedType;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ else if (stricmp(stStaticinfo.strMachineType, "RPM.Stand1S") == 0) {
|
|
|
+ eType = eRpm1sType;
|
|
|
+ }
|
|
|
+ else if (stricmp(stStaticinfo.strMachineType, "RVC.Desk1S") == 0) {
|
|
|
+ eType = eDesk1SType;
|
|
|
+ }
|
|
|
+ else if (stricmp(stStaticinfo.strMachineType, "RVC.CardStore") == 0 || stricmp(stStaticinfo.strMachineType, "RVC.CardPrinter") == 0) {
|
|
|
+ eType = eCardStore;
|
|
|
+ }
|
|
|
+ else {
|
|
|
+ eType = eStand2sType;
|
|
|
+ }
|
|
|
+
|
|
|
+ if (eType >= 0 && eType < sizeof(Device_Type_Table) / sizeof(char*)) {
|
|
|
+ DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("device type is %s.", Device_Type_Table[eType]);
|
|
|
+ }
|
|
|
+
|
|
|
+ return eType;
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+SelfChekerClient::SelfChekerClient( CSalesRecorderEntity *pEntity ) : SelfCheckerService_ClientBase(pEntity)
|
|
|
+{
|
|
|
+
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+SP_BEGIN_ENTITY_MAP()
|
|
|
+SP_ENTITY(CSalesRecorderEntity)
|
|
|
+SP_END_ENTITY_MAP()
|
80274480