//--------------------------------------------------------------------------- #include "AppGlobalF.h" #include "VMSCThread.h" #include "FrmSysLogF.h" #include "FrmVmsInfoF.h" #include "FrmVmsLogF.h" #include //--------------------------------------------------------------------------- #pragma package(smart_init) //--------------------------------------------------------------------------- // Important: Methods and properties of objects in VCL can only be // used in a method called using Synchronize, for example: // // Synchronize(&UpdateCaption); // // where UpdateCaption could look like: // // void __fastcall TVMSCThread::UpdateCaption() // { // Form1->Caption = "Updated in a thread"; // } //--------------------------------------------------------------------------- #define VMSID FVmsObj->VmsId /* * 스레드 생성자 * arguments * void * return * void */ __fastcall TVMSCThread::TVMSCThread(bool CreateSuspended, int Tag, bool *ActiveIndicator) : TThread(CreateSuspended) { try { FUserTerm = false; FVmsObj = (TVmsCtlr*)Tag; FLogFile = FVmsObj->FCLog; ThreadActiveIndicator = ActiveIndicator; *ThreadActiveIndicator = true; // 정보 초기화 ClientInitInfo(); TcpClient = new TTcpClient(NULL); TcpClient->RemoteHost = FVmsObj->IpAddress; TcpClient->RemotePort = FVmsObj->LocalNo; TcpClient->BlockMode = bmBlocking; TcpClient->OnConnect = TcpClientConnect; TcpClient->OnCreateHandle = TcpClientCreateHandle; TcpClient->OnDestroyHandle = TcpClientDestroyHandle; TcpClient->OnDisconnect = TcpClientDisconnect; TcpClient->OnError = TcpClientError; TcpClient->OnReceive = TcpClientReceive; TcpClient->OnSend = TcpClientSend; Priority = tpNormal; FreeOnTerminate = true; Resume(); } catch(Exception &e) { SERROR("Thread Init Error"); Terminate(); } } //--------------------------------------------------------------------------- /* * 스레드 소멸자 * arguments * void * return * void */ __fastcall TVMSCThread::~TVMSCThread() { try { FVmsObj->Client.Status = process_fail; SAFE_DELETE(TcpClient); } catch(Exception &e) { } *ThreadActiveIndicator = false; } //--------------------------------------------------------------------------- /* * 연결 이벤트 핸들러 * arguments * void * return * void */ void __fastcall TVMSCThread::TcpClientConnect(TObject *Sender) { SINFO("Server Connect ok: %s %s", TcpClient->RemoteHost.c_str(), TcpClient->RemotePort.c_str()); ClientInitInfo(); FVmsObj->Client.Comm = state_open; FVmsObj->Client.Status = process_run; FVmsObj->ConnectTm = Now().DateTimeString(); FVmsObj->Server.Status = process_run; POST_MSG(MAINHANDLE, WM_VMS_THREAD, WM_VMS_SERVER_STTS, (int)FVmsObj); POST_MSG(MAINHANDLE, WM_VMS_THREAD, WM_VMS_CLIENT_STTS, (int)FVmsObj); } //--------------------------------------------------------------------------- /* * 연결 해제 이벤트 핸들러 * arguments * void * return * void */ void __fastcall TVMSCThread::TcpClientDisconnect(TObject *Sender) { FVmsObj->Client.Comm = state_close; FVmsObj->Client.Status = process_run; m_pState->Comm = vms_error; FVmsObj->DisconnectTm = Now().DateTimeString(); FVmsObj->Server.Status == process_fail; //POST_MSG(MAINHANDLE, WM_VMS_THREAD, WM_VMS_CLIENT_STTS, (int)FVmsObj); SINFO("Server Disconnect: %s %s", TcpClient->RemoteHost.c_str(), TcpClient->RemotePort.c_str()); POST_MSG(MAINHANDLE, WM_VMS_THREAD, WM_VMS_SERVER_STTS, (int)FVmsObj); } //--------------------------------------------------------------------------- /* * 핸들 생성 이벤트 핸들러 * arguments * void * return * void */ void __fastcall TVMSCThread::TcpClientCreateHandle(TObject *Sender) { //LDEBUG("Thread Create Handle"); } //--------------------------------------------------------------------------- /* * 핸들 소멸 이벤트 핸들러 * arguments * void * return * void */ void __fastcall TVMSCThread::TcpClientDestroyHandle(TObject *Sender) { //LDEBUG("Thread Destroy Handle"); } //--------------------------------------------------------------------------- void __fastcall TVMSCThread::Close(void) { try { FVmsObj->Client.Status == process_fail; if (TcpClient) { //if (TcpClient->Connected) { TcpClient->Close(); //Sleep(3000); } } } catch(Exception &e) { } } //--------------------------------------------------------------------------- /* * 에러 처리 이벤트 핸들러 * arguments * void * return * void */ void __fastcall TVMSCThread::TcpClientError(TObject *Sender, int SocketError) { LPVOID lpMsgBuf = NULL; try { try { FormatMessage( FORMAT_MESSAGE_ALLOCATE_BUFFER | FORMAT_MESSAGE_FROM_SYSTEM, NULL, //GetLastError(), //MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT), // Default language SocketError, MAKELANGID(LANG_ENGLISH, SUBLANG_DEFAULT), (LPTSTR) &lpMsgBuf, 0, NULL ); char *pData = (char*)lpMsgBuf; if (strlen(pData) > 2) { pData[strlen(pData)-2] = 0x00; pData[strlen(pData)-1] = 0x00; } SERROR("SocketError: (%d: %s)", SocketError, pData); } __finally { if (lpMsgBuf) LocalFree(lpMsgBuf); lpMsgBuf = NULL; } } catch(Exception &e) { } Close(); } //--------------------------------------------------------------------------- /* * 데이터 수신 이벤트 핸들러 * arguments * void * return * void */ void __fastcall TVMSCThread::TcpClientReceive(TObject *Sender, char *Buf, int &DataLen) { //LDEBUG("VMS Client Receive: %s, %d", VMSID.c_str(), DataLen); } //--------------------------------------------------------------------------- /* * 데이터 송신 이벤트 핸들러 * arguments * void * return * void */ void __fastcall TVMSCThread::TcpClientSend(TObject *Sender, char *Buf, int &DataLen) { //LDEBUG("VMS Client Send: %s, %d", VMSID.c_str(), DataLen); } //--------------------------------------------------------------------------- bool __fastcall TVMSCThread::SocketActivity(bool &AError) { bool Error, ReadReady, WriteReady, ExcepFlag; ReadReady = false; AError = false; if (!TcpClient) return ReadReady; try { Error = TcpClient->Select(&ReadReady, &WriteReady, &ExcepFlag, 0); if ((Error == false))// || (ExcepFlag == true)) //exception flag == o.o.b(out of band data receive) { AError = true; ReadReady = false; } } catch(Exception &e) { AError = true; ReadReady = false; } return ReadReady; } //--------------------------------------------------------------------------- bool __fastcall TVMSCThread::SocketActivity() { bool bResult = false; bool Error, ReadReady, WriteReady, ExcepFlag; if (!TcpClient) return bResult; try { Error = TcpClient->Select(&ReadReady, &WriteReady, &ExcepFlag, 0); if ((Error == false) || (ReadReady == true) || (ExcepFlag == true)) { bResult = true; } } catch(Exception &e) { } return bResult; } //--------------------------------------------------------------------------- /* * 클라이언트 정보 초기화 루틴 * arguments * void * return * void */ void __fastcall TVMSCThread::ClientInitInfo(void) { m_RxLen = 0; m_rcvPacketTimer = Now(); m_WatchDogTimer = Now(); m_pVmsFormList = FVmsObj->pForms; m_pState = &FVmsObj->RSTATE; FClient.State = CT_IDLE; FClient.IpAddress = FVmsObj->IpAddress; FClient.Port = FVmsObj->LocalNo; FClient.Addr = FVmsObj->Id; FClient.VmsId = FVmsObj->VmsId; FClient.TimeOut = g_AppCfg.comm.nCmdTimeOut; FClient.pollingCycleTime = g_AppCfg.comm.nPollingTime; FClient.reqStatusTimer = Now() - ITSCOMM_SECTIME(FClient.pollingCycleTime+10); FClient.sendRetry = VMS_MAX_RETRY_COUNT; FClient.sendTimer = Now(); //m_strName.sprintf("VMSC%03d", FClient.Addr); m_strName = "VMSC" + FVmsObj->VmsId; FClient.LocalCenterId = ""; FClient.CenterId = ""; FClient.LocalDomainNm = g_AppCfg.comm.sLocalDomain; FClient.DomainNm = FClient.VmsId; FClient.UserName = g_AppCfg.comm.sLoginUser; FClient.UserPasswd = g_AppCfg.comm.sLoginPswd; FClient.MaxHeartbeatTime = VMS_MAX_HEARTBEAT_TIME; FClient.DatagramSize = VMS_MAX_DATAGRAM_SIZE; m_DataPacketNumber = 0; m_SubscribeSerialNbr = 0; FLocalCmd.GeneralStatus = false; FLocalCmd.ModuleStatus = false; FLocalCmd.PowerStatus = false; FLocalCmd.ScreenDataStatusMessage = false; FLocalCmd.RealTimeDisplayMessage = false; m_pState->Comm = vms_error; #if 0 if (m_pState != NULL) { m_pState->Cpsw.Enable = bit_enable; m_pState->CollectDate = Now().FormatString("yyyymmddhhnnss"); m_pState->Door = STATE_UNKNOWN; m_pState->Heater = STATE_UNKNOWN; m_pState->Fan = STATE_UNKNOWN; m_pState->ModuleState = STATE_UNKNOWN; m_pState->Power = STATE_UNKNOWN; m_pState->Temp = 0; m_pState->Bright = 0; m_pState->ModuleHorizontal = 0; m_pState->ModuleVertical = 0; m_pState->PowerCount = 0; memset(m_pState->ModuleStatus, STATE_UNKNOWN, sizeof(m_pState->ModuleStatus)); memset(m_pState->PowerStatus, STATE_UNKNOWN, sizeof(m_pState->PowerStatus)); } #endif InitRx(); LINFO("ClientInitInfo ok"); } //--------------------------------------------------------------------------- void __fastcall TVMSCThread::InitRx() { m_RxPktLen = 0; m_RxLen = 0; m_RxState = RX_STX; memset(m_RxBuff, 0x00, sizeof(m_RxBuff)); } //--------------------------------------------------------------------------- void __fastcall TVMSCThread::ClientTerminate(void) { try { FVmsObj->Client.Comm = state_close; FVmsObj->Client.Status = process_fail; FVmsObj->Client.pThread = NULL; FVmsObj->Client.ActiveIndicator = false; //POST_MSG(MAINHANDLE, WM_VMS_THREAD, WM_VMS_CLIENT_STTS, (int)FVmsObj); SINFO("Thread stop"); } catch(Exception &e) { } } //--------------------------------------------------------------------------- int HexArr2BinArr(unsigned char *AHexData, unsigned char *AResult) { //TODO: 결과를 리턴할 메모리의 크기는 체크하지 않음 int nLen = 0; unsigned const char *pos = AHexData; char *endptr = NULL; int count = (strlen(AHexData) / 2); if ((AHexData[0] == NULL) || (strlen(AHexData) % 2)) { //데이터가 없거나 길이가 짝수가 아닌경우 return -2; } for(int ii = 0; ii < count; ii++) { char buf[5] = {'0', 'x', pos[0], pos[1], 0}; AResult[nLen++] = (unsigned char)strtol(buf, &endptr, 0); pos += 2 * sizeof(char); if (endptr[0] != '\0') { //Hex 문자열이 아님 return -1; } } #if 0 BYTE chn, cln, val; chn = (BYTE)szData[0]; cln = (BYTE)szData[1]; hn = chn > '9' ? chn - 'A' + 10 : chn - '0'; ln = cln > '9' ? cln - 'A' + 10 : cln - '0'; val = (BYTE)((hn << 4 ) | ln); RxBuff[RxLen] = val; #endif return nLen; } //--------------------------------------------------------------------------- void __fastcall TVMSCThread::Execute() { BYTE rcvBuff[DEFAULT_TCP_PACKET_MAX_SIZE]; int rcvLen; int nError; int nResult; bool bError; //static bool first = true; try { NameThreadForDebugging(m_strName); FErrLine = 0; SINFO("Thread start"); try { while (!Terminated && !FUserTerm && !g_AppCfg.bThrExit) { FVmsObj->Client.Status = process_run; m_pState->Comm = vms_error; SINFO("Server connect try: %s.%s", TcpClient->RemoteHost.c_str(), TcpClient->RemotePort.c_str()); TcpClient->Open(); bError = false; while (!Terminated && TcpClient->Connected && !FUserTerm && !g_AppCfg.bThrExit) { m_pState->Comm = vms_normal; try { if (SYS_ERR_OFFLINE == ClientStateMachine()) { if (FClient.State == CT_CLOSE) { break; } } bError = false; if (TcpClient->WaitForData(100) || SocketActivity()) { bError = false; memset(rcvBuff, 0, sizeof(rcvBuff)); rcvLen = TcpClient->ReceiveBuf(rcvBuff, sizeof(rcvBuff)); if (rcvLen > 0) { if ((nResult = RecvPacket(rcvBuff, rcvLen)) != SYS_ERR_NONE) { ProcErrorState(true, nResult); } } else { bError = true; } } if (bError) { SERROR("Socket Error[Closed]...."); nError = -3; Close(); } if (FVmsObj->Server.Status != process_run) { nError = -4; Close(); } } catch(Exception &e) { SERROR("Thread execute exception: %s, Line: %d", AnsiString(e.Message).c_str(), FErrLine); nError = -2; Close(); } } if (FClient.State == CT_CLOSE || FUserTerm || g_AppCfg.bThrExit) { nError = 0; SINFO("Thread exit catched....2"); Close(); break; } if (FVmsObj->Client.Status != process_stop) { Sleep(g_AppCfg.comm.nConnectWait * 1000); } } SERROR("Term: %d, Conn: %d, Err: %d, Line: %d, AppExit: %d, UserTerm: %d", Terminated, TcpClient->Connected, nError, FErrLine, g_AppCfg.bThrExit, FUserTerm); } __finally { TcpClient->Close(); Terminate(); FUserTerm = false; } } catch(Exception &e) { SERROR("Thread execute error: %s", AnsiString(e.Message).c_str()); Terminate(); } m_pState->Comm = vms_error; ClientTerminate(); } //--------------------------------------------------------------------------- void __fastcall TVMSCThread::DebugState() { switch(FClient.State) { case 1: break; default: break; } } //--------------------------------------------------------------------------- bool __fastcall TVMSCThread::IsCommandTimeout() { // 마지막 전송시각이 타임아웃 시각보다 큰경우 return CommUtil_TimeDiff(FClient.sendTimer) > FClient.TimeOut ? true : false; } //--------------------------------------------------------------------------- /* * 클라이언트 상태에 따른 처리 * arguments * void * return * void */ int __fastcall TVMSCThread::ClientStateMachine(void) { FErrLine = 13; int result; bool bRequest; result = SYS_ERR_NONE; // CMDTIMEOUT 체크 // 현재 수신데이터가 있고 마지막 수진시각이 타임아웃보다 크면 // 수신 타임아웃으로 처리한다. if (m_RxLen && (CommUtil_TimeDiff(m_rcvPacketTimer) > FClient.TimeOut)) { InitRx(); m_RxLen = 0; ProcErrorState(true, SYS_ERR_RECEIVE_TIMEOUT); return result; } DebugState(); switch(FClient.State) { case CT_CLOSE: LERROR("STATE: CT_CLOSE"); Terminate(); result = SYS_ERR_OFFLINE; break; case CT_IDLE: FClient.reqStatusTimer = Now() - ITSCOMM_SECTIME(CLIENT_CONNECT_RETRY_TIME - CLIENT_CHANGE_TIME); FClient.State = CT_SECTION; break; case CT_SECTION: #if 0 if (CommUtil_TimeDiff(m_WatchDogTimer) > g_AppCfg.comm.nWatchDogTime) { LERROR("STATE: ST_SECTION - WatchDog Time over"); FClient.State = CT_CLOSE; break; } #endif if (CommUtil_TimeDiff(FClient.reqStatusTimer) > FClient.pollingCycleTime) { FClient.reqStatusTimer = Now(); FLocalCmd.GeneralStatus = false; FLocalCmd.ModuleStatus = false; FLocalCmd.PowerStatus = false; } FClient.State = CT_LOCAL_COMMAND; break; case CT_LOCAL_COMMAND: result = CheckLocalData(bRequest); if (bRequest) { if (result == SYS_ERR_NONE) FClient.State = CT_LOCAL_WAIT; else { if (--FClient.sendRetry <= 0) FClient.State = CT_CLOSE; } } else FClient.State = CT_CLIENT_COMMAND; break; case CT_CLIENT_COMMAND: result = CheckClientData(bRequest); if (bRequest) { if (result == SYS_ERR_NONE) FClient.State = CT_CLIENT_WAIT; else { if (--FClient.sendRetry <= 0) FClient.State = CT_CLOSE; } } else FClient.State = CT_SECTION; break; case CT_CLIENT_WAIT: case CT_LOCAL_WAIT: if (IsCommandTimeout()) { // Local Command에 대한 타임아웃이 발생한 경우 if (FClient.sendRetry > 0) { // 타임아웃 카운트 보다 작을 경우 Command를 전송한다. if (FClient.State == CT_CLIENT_WAIT) FClient.State = CT_CLIENT_COMMAND; else if (FClient.State == CT_LOCAL_WAIT) FClient.State = CT_LOCAL_COMMAND; } else { // 타임아웃 카운트 보다 큰 경우 종료 FClient.State = CT_CLOSE; } } break; default: FClient.State = CT_IDLE; break; } if (result) { ProcErrorState(false, result); } return result; } //--------------------------------------------------------------------------- /* * 프로세스 자체(주기)적으로 VMS로 전송(요청)되어야 할 패킷이 있는지 확인하고 처리한다. * arguments * void * return * void */ int __fastcall TVMSCThread::CheckLocalData(bool &ARequest) { int result = SYS_ERR_NONE; COMMAND_ARGUMENT arg; memset(&arg, 0x00, sizeof(arg)); FLocalCmd.OpCode = 0x00; FLocalCmd.obj = OBJ_None; /* EN_OBJECT_ID */ FLocalCmd.DataPacketNumber = 0; /* DataPacket Number */ FLocalCmd.Idx = 0; ARequest = true; /* 상태정보 요청 확인 */ if (FLocalCmd.GeneralStatus == false) { //LINFO("**** REQ_VMS_STATUS"); arg.Subscription.nbr = NBR_GENERAL_STATUS; //arg.Subscription.mode = SubscriptionMode_PR_single; arg.Subscription.delay = 60; arg.Subscription.obj = OBJ_GeneralStatus; FLocalCmd.OpCode = REQ_VMS_STATUS; FLocalCmd.obj = OBJ_GeneralStatus; FLocalCmd.DataPacketNumber = m_DataPacketNumber; result = ProcessSendPacket(FLocalCmd.OpCode, &arg); return result; } // 모듈상태 요청 확인 if (FLocalCmd.ModuleStatus == false) { //LINFO("**** REQ_VMS_MODULE_STATUS"); arg.Subscription.nbr = NBR_MODULE_STATUS; //arg.Subscription.mode = SubscriptionMode_PR_single; arg.Subscription.delay = 60; arg.Subscription.obj = OBJ_ModuleStatus; FLocalCmd.OpCode = REQ_VMS_MODULE_STATUS; FLocalCmd.obj = OBJ_ModuleStatus; FLocalCmd.DataPacketNumber = m_DataPacketNumber; result = ProcessSendPacket(FLocalCmd.OpCode, &arg); return result; } // FORM 다운로드 if (FVmsObj->CTLMODE->Enable == object_enable) { m_pVmsFormList->Lock(); try { int nFormCnt = m_pVmsFormList->Count(); for (int ii = 0; ii < nFormCnt; ii++) { TVmsForm *pVmsForm = m_pVmsFormList->GetItem(ii); if (pVmsForm) { if (pVmsForm->SvcRes == false) { arg.Publication.SubscribeSerialNbr = NBR_BASE_REALTIMEDISPLAY; arg.Publication.obj = OBJ_RealTimeDisplay; arg.Publication.Data.Form.Idx = 0; FLocalCmd.OpCode = REQ_VMS_MSG_DOWNLOAD;//REQ_VMS_LIB_DOWNLOAD;//REQ_VMS_MSG_DOWNLOAD; FLocalCmd.obj = OBJ_RealTimeDisplay; FLocalCmd.DataPacketNumber = 0; FLocalCmd.Idx = nFormCnt; break; } } } arg.Publication.Data.Form.Mode = FVmsObj->CTLMODE->Control; } __finally { m_pVmsFormList->UnLock(); } if (FLocalCmd.OpCode != 0x00) { result = ProcessSendPacket(FLocalCmd.OpCode, &arg); return result; } } ARequest = false; return result; } //--------------------------------------------------------------------------- /* * * arguments * void * return * void */ int __fastcall TVMSCThread::CheckClientData(bool &ARequest) { FErrLine = 24; int nResult = VERR_NONE; IPCUDPPACKET *pPI = NULL; TList *pPackQueue; COMMAND_ARGUMENT arg; ARequest = false; try { pPackQueue = FVmsObj->pPackQueue->LockList(); int nCmdCnt = pPackQueue->Count; for (int ii = nCmdCnt-1; ii >= 0; ii--) { pPI = (IPCUDPPACKET *)pPackQueue->Items[ii]; if (pPI->Data == NULL) { delete pPI; pPackQueue->Delete(ii); continue; } memset((char*)&FCliCmd, 0x00, sizeof(FCliCmd)); memset((char*)&arg, 0x00, sizeof(arg)); FCliCmd.OpCode = 0x00; FCliCmd.obj = OBJ_None; /* EN_OBJECT_ID */ FCliCmd.DataPacketNumber = 0; /* DataPacket Number */ FCliCmd.Idx = 0; INT_VMS_POWER_CTL_REQ *pHd = (INT_VMS_POWER_CTL_REQ*)pPI->Data; memcpy(FCliCmd.VmsId, pHd->VmsId, INT_VMS_MAX_ID); memcpy(FCliCmd.OperId, pHd->OperId, INT_VMS_MAX_OPER_ID); memcpy(FCliCmd.CmdTime, pHd->CmdTime, INT_VMS_MAX_DATETIME); FCliCmd.Result = CTL_RESULT_FAIL; switch(pPI->OPCode) { case INT_OP_VMS_POWER_CTL: { INT_VMS_POWER_CTL_REQ *pReq = (INT_VMS_POWER_CTL_REQ*)pPI->Data; FCliCmd.OpCode = REQ_SIGNBOARD_POWER_CONTROL; arg.Publication.SubscribeSerialNbr = NBR_MODULE_POWER; arg.Publication.obj = OBJ_StatusControl; arg.Publication.Data.Ctl = (pReq->Command == vms_board_power_on) ? 0x01 : 0x00; } break; case INT_OP_VMS_RESET: { INT_VMS_RESET_REQ *pReq = (INT_VMS_RESET_REQ*)pPI->Data; FCliCmd.OpCode = REQ_VMS_INITIALIZE; } break; case INT_OP_VMS_DIRECT: { INT_VMS_DIRECT_CTL_REQ *pReq = (INT_VMS_DIRECT_CTL_REQ*)pPI->Data; FCliCmd.OpCode = pReq->Command; } break; case INT_OP_VMS_LUMINANCE_CTL: { INT_VMS_LUMINANCE_REQ *pReq = (INT_VMS_LUMINANCE_REQ*)pPI->Data; arg.Publication.SubscribeSerialNbr = NBR_LUMINANCE; arg.Publication.obj = OBJ_StatusControl; arg.Publication.Data.Ctl = pReq->Luminance; FCliCmd.OpCode = REQ_VMS_LUMINANCE_LEVEL_SET; } break; case INT_OP_VMS_PARA_SET2: { INT_VMS_PARA_SET_REQ2 *pReq = (INT_VMS_PARA_SET_REQ2*)pPI->Data; memcpy(FCliCmd.VmsId, pReq->VmsId, INT_VMS_MAX_ID); memcpy(FCliCmd.OperId, pReq->OperId, INT_VMS_MAX_OPER_ID); memcpy(FCliCmd.CmdTime, pReq->CmdTime, INT_VMS_MAX_DATETIME); arg.Publication.SubscribeSerialNbr = NBR_STATUS_SETTING; arg.Publication.obj = OBJ_StatusSetting; arg.Publication.Data.Set2.DefCommErr = pReq->DefCommErr; // 통신장애 기본값, 제어기가 Host로부터 Poll 또는 명령을 받지 않고 경과할 수 있는 최대시간 (default ; 60초) arg.Publication.Data.Set2.SlotCommErr = pReq->SlotCommErr; // 통신장애 slot번호, 통신 fail 시 표시할 메시지 번호(default 0번) arg.Publication.Data.Set2.SlotPowerErr = pReq->SlotPowerErr; // 전원장애 slot번호, 전원장애 시 표시할 메시지 번호(default 0번) arg.Publication.Data.Set2.NightLuminance = pReq->NightLuminance; // 야간 휘도 값, 0x30 ~ 0x3F arg.Publication.Data.Set2.DayLuminance = pReq->DayLuminance; // 주간 휘도 값, 0x40 ~ 0x4F arg.Publication.Data.Set2.PhaseCycleTime = pReq->PhaseCycleTime; // phase시간주기, 장애시 phase주기 (default : 3초, 범위 : 0 ~ 10초) arg.Publication.Data.Set2.ModuleFailRate = pReq->ModuleFailRate; // 모듈장애율, 한개의 module을 장애로 처리하기 위한 장애 pixel백분율 (default 10%) arg.Publication.Data.Set2.ModuleCheckTime = pReq->ModuleCheckTime; // 모듈감시 주기, 0 ~ 255 (단위:초) arg.Publication.Data.Set2.BoardOnHour = pReq->BoardOnHour; // 전광판 On time(시), 0시 ~ 23시 arg.Publication.Data.Set2.BoardOnMin = pReq->BoardOnMin; // 전광판 On time(분), 0시 ~ 23시 arg.Publication.Data.Set2.BoardOffHour = pReq->BoardOffHour; // 전광판 Off time(시), 0시 ~ 23시 arg.Publication.Data.Set2.BoardOffMin = pReq->BoardOffMin; // 전광판 Off time(분), 0시 ~ 23시 FVmsObj->VMS_CMNC_ERR_BASS_VAL = (int)pReq->DefCommErr; FVmsObj->CMNCFAIL_SLOT_NMBR = (int)pReq->SlotCommErr; // NUMBER(4) Y 0 통신장애 SLOT 번호 FVmsObj->PWER_FAIL_SLOT_NMBR = (int)pReq->SlotPowerErr; // NUMBER(4) Y 0 전원 장애 SLOT 번호 FVmsObj->VMS_NGHT_BRGH_STEP = (int)pReq->NightLuminance; FVmsObj->VMS_WEEK_BRGH_STEP = (int)pReq->DayLuminance; //FVmsObj->VMS_PHSE_CHNG_CYCL = (int)pReq->PhaseCycleTime; FVmsObj->VMS_MODL_ERR_RATE = (int)pReq->ModuleFailRate; FVmsObj->VMS_MODL_CHK_CYCL = (int)pReq->ModuleCheckTime; //m_State.ModuleOperatingTemperature = FVmsObj->VMS_CMNC_ERR_BASS_VAL; /* 필수 모듈 전원이 꺼지는 온도값(℃) */ #if 0 AnsiString sOn, sOff; sOn.printf("%02d%02d", (int)pReq->BoardOnHour, (int)pReq->BoardOnMin); sOff.printf("%02d%02d", (int)pReq->BoardOffHour, (int)pReq->BoardOffMin); FVmsObj->MODULE.PowerOnTime = Now().FormatString("yyyymmdd") + sOn; FVmsObj->MODULE.PowerOffTime = Now().FormatString("yyyymmdd") + sOff; #endif FCliCmd.OpCode = REQ_VMS_PARAM_DOWNLOAD; } break; #if 0 case INT_OP_VMS_PARA_SET: { INT_VMS_PARA_SET_REQ *pReq = (INT_VMS_PARA_SET_REQ*)pPI->Data; memcpy(FCliCmd.VmsId, pReq->VmsId, INT_VMS_MAX_ID); memcpy(FCliCmd.OperId, pReq->OperId, INT_VMS_MAX_OPER_ID); memcpy(FCliCmd.CmdTime, pReq->CmdTime, INT_VMS_MAX_DATETIME); arg.Publication.SubscribeSerialNbr = NBR_STATUS_SETTING; arg.Publication.obj = OBJ_StatusSetting; arg.Publication.Data.Set.SchMsgTime = (int)pReq->SchMsgTime; arg.Publication.Data.Set.ModuleTemp = (int)pReq->ModuleTemp; arg.Publication.Data.Set.FanTemp = (int)pReq->FanTemp; arg.Publication.Data.Set.HeaterTemp = (int)pReq->HeaterTemp; arg.Publication.Data.Set.ModuleFail = (int)pReq->ModuleFail; arg.Publication.Data.Set.RetryCount = (int)pReq->RetryCount; arg.Publication.Data.Set.TimeOut = (int)pReq->TimeOut; FCliCmd.Data.Para.SchMsgTime = (int)pReq->SchMsgTime; FCliCmd.Data.Para.ModuleTemp = (int)pReq->ModuleTemp; FCliCmd.Data.Para.FanTemp = (int)pReq->FanTemp; FCliCmd.Data.Para.HeaterTemp = (int)pReq->HeaterTemp; FCliCmd.Data.Para.ModuleFail = (int)pReq->ModuleFail; FCliCmd.Data.Para.RetryCount = (int)pReq->RetryCount; FCliCmd.Data.Para.TimeOut = (int)pReq->TimeOut; FCliCmd.OpCode = CTL_TYPE_PARA_SET; FCliCmd.obj = AI_StatusSettingMessage; } break; #endif default: nResult = VERR_UNKNOWN_COMMAND; break; } if (nResult == VERR_NONE) { nResult = ProcessSendPacket(FCliCmd.OpCode, &arg); } //ClientResponse(nResult); if (pPI->Size > 0) { delete []pPI->Data; } delete pPI; pPI = NULL; pPackQueue->Delete(ii); ARequest = true; break; } } __finally { FVmsObj->pPackQueue->UnlockList(); } return nResult; } //--------------------------------------------------------------------------- void __fastcall TVMSCThread::ClientResponse(int error) { #ifdef CENTERCOMM BYTE ErrCode; int sResult; int Flag; bool bSave = false; switch(error) { case SYS_ERR_NONE: break; case SYS_ERR_OTHER: ErrCode = INT_ERROR_OTHER; break; case SYS_ERR_INTERNAL: ErrCode = INT_ERROR_SYSTEM; break; case SYS_ERR_MEMORY: ErrCode = INT_ERROR_SYSTEM; break; case SYS_ERR_DATABASE: ErrCode = INT_ERROR_SYSTEM; break; case SYS_ERR_RESET: ErrCode = INT_ERROR_SYSTEM; break; case SYS_ERR_START: ErrCode = INT_ERROR_SYSTEM; break; case SYS_ERR_OFFLINE: ErrCode = INT_ERROR_OFFLINE; break; case SYS_ERR_NO_RES: ErrCode = INT_ERROR_NO_RESPONSE; break; case SYS_ERR_ACCESS: ErrCode = INT_ERROR_PROCESS; break; case SYS_ERR_INVALID: ErrCode = INT_ERROR_OTHER; break; case SYS_ERR_UNKNOWN: ErrCode = INT_ERROR_UNKNOWN_CODE; break; case SYS_ERR_WRITE_LENGTH: ErrCode = INT_ERROR_OTHER; break; case SYS_ERR_PACKET_SIZE_LARGE: ErrCode = INT_ERROR_OTHER; break; case SYS_ERR_INVALID_TAG: ErrCode = INT_ERROR_OTHER; break; case SYS_ERR_CRC: ErrCode = INT_ERROR_OTHER; break; case SYS_ERR_LENGTH: ErrCode = INT_ERROR_LENGTH; break; case SYS_ERR_ADDRESS: ErrCode = INT_ERROR_ADDRESS; break; case SYS_ERR_HEADER_OPTIONS: ErrCode = INT_ERROR_HEADER; break; case SYS_ERR_UNKNOWN_COMMAND: ErrCode = INT_ERROR_UNKNOWN_OPCODE; break; case SYS_ERR_RECEIVE_TIMEOUT: ErrCode = INT_ERROR_OTHER; break; case SYS_ERR_DATA_SIZE: ErrCode = INT_ERROR_DISCORD; break; case SYS_ERR_MISMATCH: ErrCode = INT_ERROR_OTHER; break; case SYS_ERR_INVALID_PARA: ErrCode = INT_ERROR_INVALID_DATA; break; case SYS_ERR_MOVEMENT: ErrCode = INT_ERROR_MOVEMENT; break; case SYS_ERR_UNAUTHORIZED: ErrCode = INT_ERROR_UNAUTHORIZED; break; default: ErrCode = INT_ERROR_OTHER; break; } switch (m_Req.OpCode) { case INT_OP_VMS_POWER_CTL: /* 0x0303 VMS 통신 서버, VMS 전광판 On/Off 제어 */ if (error == SYS_ERR_NONE) { Flag = SEND_ACK; m_Set.Data.Control.Result = CTL_RESULT_SUCC; } else { Flag = SEND_NACK; } bSave = true; break; case INT_OP_VMS_PARA_SET: /* 0x0308 VMS 통신 서버, VMS 환경설정정보 전송 */ if (error == SYS_ERR_NONE) { Flag = SEND_ACK; bSave = true; } else { Flag = SEND_NACK; } break; case INT_OP_VMS_RESET: /* 0x0309 VMS 통신 서버, VMS 제어기 리셋 전송 */ if (error == SYS_ERR_NONE) { Flag = SEND_ACK; m_Set.Data.Control.Result = CTL_RESULT_SUCC; } else { Flag = SEND_NACK; } bSave = true; break; default: Flag = SEND_NONE; break; } if (bSave == true) { if ((sResult = SendDbThreadDataMessage(WM_DATA_SAVE, (void *)&m_Set, sizeof(m_Set))) != SYS_ERR_NONE) { } } if (Flag == SEND_ACK) { INT_ACK_RES Ack; memset(&Ack, 0x00, sizeof(Ack)); Ack.OPCode.Type = INT_TYPE(m_Req.OpCode); Ack.OPCode.Kind = INT_KIND(m_Req.OpCode); Ack.MsgSeq = m_Req.MsgSeq; if ((sResult = AckRes(&Ack, m_Req.ProcessID)) != UDP_ERR_NONE) { } } else if (Flag == SEND_NACK) { INT_NACK_RES Nack; memset(&Nack, 0x00, sizeof(Nack)); Nack.OPCode.Type = INT_TYPE(m_Req.OpCode); Nack.OPCode.Kind = INT_KIND(m_Req.OpCode); Nack.MsgSeq = m_Req.MsgSeq; Nack.ErrCode = ErrCode; if ((sResult = NackRes(&Nack, m_Req.ProcessID)) != UDP_ERR_NONE) { } } #endif } //--------------------------------------------------------------------------- int __fastcall TVMSCThread::SendDbThreadMessage(UINT Msg, int wParam, int lParam) { int result; result = SYS_ERR_OTHER; if (g_SysInfo->State.CommThreadID != NULL) { if (PostThreadMessage(g_SysInfo->State.CommThreadID, Msg, (WPARAM)wParam, (LPARAM)lParam)) { result = SYS_ERR_NONE; } else { result = SYS_ERR_INTERNAL; } } return result; } //--------------------------------------------------------------------------- int __fastcall TVMSCThread::SendDbThreadDataMessage(UINT Msg, void *pData, int iLen) { int nResult; char *p; nResult = VERR_OTHER; if (g_SysInfo->State.CommThreadID != NULL) { p = new char[iLen]; if (p != NULL) { try { memcpy(p, pData, iLen); if (PostThreadMessage(g_SysInfo->State.CommThreadID, Msg, (WPARAM)p, NULL)) { nResult = VERR_NONE; Sleep(50); } else { nResult = VERR_INTERNAL; } } __finally { if (nResult != VERR_NONE) { delete []p; } } } else { nResult = VERR_MEMORY_ALLOC; } } return nResult; } //--------------------------------------------------------------------------- /* * 에러 처리 * arguments * void * return * void */ int __fastcall TVMSCThread::ProcErrorState(bool flag, int result) { FErrLine = 14; #if 1 { AnsiString strLog; switch(result) { case SYS_ERR_NONE: strLog.sprintf("no error [%d]", result); break; case SYS_ERR_OTHER: strLog.sprintf("other [%d]", result); break; case SYS_ERR_INTERNAL: strLog.sprintf("internal system error(kernel..) [%d]", result); break; case SYS_ERR_MEMORY: strLog.sprintf("memory overflow [%d]", result); break; case SYS_ERR_DATABASE: strLog.sprintf("system database error [%d]", result); break; case SYS_ERR_RESET: strLog.sprintf("system reset [%d]", result); break; case SYS_ERR_START: strLog.sprintf("system start [%d]", result); break; case SYS_ERR_OFFLINE: strLog.sprintf("offline [%d]", result); break; case SYS_ERR_NO_RES: strLog.sprintf("no response [%d]", result); break; case SYS_ERR_ACCESS: strLog.sprintf("access denied [%d]", result); break; case SYS_ERR_INVALID: strLog.sprintf("invalid data type [%d]", result); break; case SYS_ERR_UNKNOWN: strLog.sprintf("unknown data type [%d]", result); break; case SYS_ERR_WRITE_LENGTH: strLog.sprintf("write length [%d]", result); break; case SYS_ERR_PACKET_SIZE_LARGE: strLog.sprintf("packet size large [%d]", result); break; case SYS_ERR_INVALID_TAG: strLog.sprintf("invalid tag [%d]", result); break; case SYS_ERR_CRC: strLog.sprintf("crc [%d]", result); break; case SYS_ERR_LENGTH: strLog.sprintf("length [%d]", result); break; case SYS_ERR_ADDRESS: strLog.sprintf("address [%d]", result); break; case SYS_ERR_HEADER_OPTIONS: strLog.sprintf("header options [%d]", result); break; case SYS_ERR_UNKNOWN_COMMAND: strLog.sprintf("unknown command [%d]", result); break; case SYS_ERR_RECEIVE_TIMEOUT: strLog.sprintf("receive timeout [%d]", result); break; case SYS_ERR_DATA_SIZE: strLog.sprintf("data size [%d]", result); break; case SYS_ERR_MISMATCH: strLog.sprintf("mismatch command [%d]", result); break; case SYS_ERR_INVALID_PARA: strLog.sprintf("invalid parameter [%d]", result); break; case SYS_ERR_MOVEMENT: strLog.sprintf("movement [%d]", result); break; case SYS_ERR_UNAUTHORIZED: strLog.sprintf("unauthorized [%d]", result); break; case SYS_ERR_DATEXDATAPACKET_DECODE: strLog.sprintf("DatexDataPacket decode [%d]", result); break; case SYS_ERR_INVALID_VERSION_NUMBER: strLog.sprintf("invalid version number [%d]", result); break; case SYS_ERR_C2CAUTHENTICATEDMESSAGE_DECODE: strLog.sprintf("C2CAuthenticatedMessage decode [%d]", result); break; case SYS_ERR_C2CAUTHENTICATEDMESSAGE: strLog.sprintf("C2CAuthenticatedMessage [%d]", result); break; case SYS_ERR_NOT_LOGIN: strLog.sprintf("Not login [%d]", result); break; case SYS_ERR_ACCEPT_TYPE: strLog.sprintf("Accept Type [%d]", result); break; case SYS_ERR_DATEXPUBLISH_FORMAT: strLog.sprintf("datexPublish Format [%d]", result); break; case SYS_ERR_DATEXPUBLISH_TYPE: strLog.sprintf("datexPublish Type [%d]", result); break; case SYS_ERR_UNKNOWN_MESSAGE_ID: strLog.sprintf("unknown Message id [%d]", result); break; case SYS_ERR_MESSAGE_DECODE: strLog.sprintf("Message decode [%d]", result); break; case SYS_ERR_DATEXDATAPACKET_ENCODE: strLog.sprintf("DatexDataPacket encode [%d]", result); break; case SYS_ERR_C2CAUTHENTICATEDMESSAGE_ENCODE: strLog.sprintf("C2CAuthenticatedMessage encode [%d]", result); break; case SYS_ERR_MESSAGE_ENCODE: strLog.sprintf("Message encode [%d]", result); break; case SYS_ERR_PUBLICATIONDATA_ENCODE: strLog.sprintf("PublicationData encode [%d]", result); break; case SYS_ERR_MISMATCH_DESTINATION_TEXT: strLog.sprintf("mismatch Destination text [%d]", result); break; case SYS_ERR_DATEXLOGIN_VALUE: strLog.sprintf("Login Value [%d]", result); break; case SYS_ERR_SUBSCRIPTION_TYPE: strLog.sprintf("SubscriptionType Type [%d]", result); break; case SYS_ERR_SUBSCRIPTION_STATUS_VALUE: strLog.sprintf("SubscriptionType Status Value [%d]", result); break; case SYS_ERR_SUBSCRIPTION_MODE_VALUE: strLog.sprintf("SubscriptionType Mode Value [%d]", result); break; case SYS_ERR_SUBSCRIPTION_FORMAT_VALUE: strLog.sprintf("SubscriptionType Format Value [%d]", result); break; case SYS_ERR_HANGUL_CONVERSION: strLog.sprintf("Hangul Conversion [%d]", result); break; case SYS_ERR_INVALID_TAGANDLEN: strLog.sprintf("invalid Tag And Len [%d]", result); break; case SYS_ERR_PUBLICATIONDATA_DECODE: strLog.sprintf("PublicationData decode [%d]", result); break; default: strLog.sprintf("Unknown Error [%d]", result); break; } if (flag){ LERROR("Recv Error %s", strLog.c_str()); }else{ LERROR("Send Error %s", strLog.c_str()); } } #endif return 0; } //--------------------------------------------------------------------------- /* * 상태 변경 * arguments * void * return * void */ int __fastcall TVMSCThread::SetClientState(int ACase) { FErrLine = 15; switch(FClient.State) { case CT_LOGIN_WAIT: if (ACase == SET_CLIENT_SUCC) { if (FVmsObj->FIsOldProtocol) { //정보요청을 등록해야함(기존 VMS) FClient.State = CT_SECTION;//CT_REGIST; //TODO FClient.reqStatusTimer = Now() - ITSCOMM_SECTIME(FClient.pollingCycleTime); } else { FClient.State = CT_SECTION; FClient.reqStatusTimer = Now() - ITSCOMM_SECTIME(FClient.pollingCycleTime); } } else if (ACase == SET_CLIENT_FAIL) { FClient.State = CT_IDLE; } break; case CT_FRED_WAIT: FClient.State = CT_SECTION; break; case CT_LOCAL_WAIT: if (ACase == SET_CLIENT_SUCC) { FClient.State = CT_LOCAL_COMMAND;//CT_CLIENT_COMMAND; } else if (ACase == SET_CLIENT_FAIL) { FClient.State = CT_LOCAL_COMMAND; } break; case CT_CLIENT_WAIT: if (ACase == SET_CLIENT_SUCC) { FClient.State = CT_SECTION; } else if (ACase == SET_CLIENT_FAIL) { FClient.State = CT_CLIENT_COMMAND; } break; case CT_REGIST_WAIT: if (ACase == SET_CLIENT_SUCC) { FClient.State = CT_REGIST_COMMAND; } else if (ACase == SET_CLIENT_FAIL) { FClient.State = CT_CLIENT_COMMAND; } break; default: break; } return 0; } //--------------------------------------------------------------------------- void __fastcall TVMSCThread::InfoPacket(BYTE *ABuff, int ALen, bool ASend, int AResult/*=0*/) { VMS_PACKET *Pkt = (VMS_PACKET*)ABuff; AnsiString sCmd = ""; ACK_NAK res; bool acknak = true; switch(Pkt->hd.OpCode) { case REQ_VMS_STATUS: acknak = false; if (ASend) sCmd = "REQ_VMS_STATUS"; else sCmd = "RES_VMS_STATUS"; break; case REQ_VMS_MSG_DOWNLOAD: if (ASend) sCmd = "REQ_VMS_MSG_DOWNLOAD"; else sCmd = "RES_VMS_MSG_DOWNLOAD"; break; case REQ_VMS_LIB_DOWNLOAD: if (ASend) sCmd = "REQ_VMS_LIB_DOWNLOAD"; else sCmd = "RES_VMS_LIB_DOWNLOAD"; break; case REQ_VMS_PARAM_DOWNLOAD: if (ASend) sCmd = "REQ_VMS_PARAM_DOWNLOAD"; else sCmd = "RES_VMS_PARAM_DOWNLOAD"; break; case REQ_VMS_BLANK_DISP: if (ASend) sCmd = "REQ_VMS_BLANK_DISP"; else sCmd = "RES_VMS_BLANK_DISP"; break; case REQ_VMS_DEF_MSG_DISP: if (ASend) sCmd = "REQ_VMS_DEF_MSG_DISP"; else sCmd = "RES_VMS_DEF_MSG_DISP"; break; case REQ_VMS_MODULE_STATUS: acknak = false; if (ASend) sCmd = "REQ_VMS_MODULE_STATUS"; else sCmd = "RES_VMS_MODULE_STATUS"; break; case REQ_VMS_INITIALIZE: if (ASend) sCmd = "REQ_VMS_INITIALIZE"; else sCmd = "RES_VMS_INITIALIZE"; break; case REQ_VMS_LUMINANCE_LEVEL_SET: if (ASend) sCmd = "REQ_VMS_LUMINANCE_LEVEL_SET"; else sCmd = "RES_VMS_LUMINANCE_LEVEL_SET"; break; case REQ_SIGNBOARD_POWER_CONTROL: if (ASend) sCmd = "REQ_SIGNBOARD_POWER_CONTROL"; else sCmd = "RES_SIGNBOARD_POWER_CONTROL"; break; default: if (ASend) LERROR("Send Unknown OpCode: %02X, %d Bytes", Pkt->hd.OpCode, ALen); else LERROR("Recv Unknown OpCode: %02X, %d Bytes", Pkt->hd.OpCode, ALen); return; } if (ASend) { if (AResult == SYS_ERR_NONE) LINFO("Send: %s, %d Bytes", sCmd.c_str(), ALen); else LINFO("Send Fail: %s, %d Bytes", sCmd.c_str(), ALen); } else { if (acknak) { res.ack = ABuff[POS_ACKNAK]; if (res.ack == 0x00) LINFO("Recv: %s, %d Bytes", sCmd.c_str(), ALen); else LINFO("Recv: %s, %d Bytes, NAK(%d,%d,%d,%d,%d)", sCmd.c_str(), ALen, res.nak.crc, res.nak.cmd, res.nak.dat, res.nak.nbr, res.nak.chk ); } else { LINFO("Recv: %s, %d Bytes", sCmd.c_str(), ALen); } } } //--------------------------------------------------------------------------- void TVMSCThread::ReqStatus() { try { FClient.reqStatusTimer = Now() - ITSCOMM_SECTIME(FClient.pollingCycleTime+10); } catch(Exception &e) { } } //--------------------------------------------------------------------------- int TVMSCThread::LogData(char *ASndRcv, BYTE *AData, int ALen) { int result = -1; int nStep = 0; if (!FLogFile) return result; if (!FLogFile->FLogCfg.Data) return result; try { FLogFile->LogData(ASndRcv, AData, ALen); if (FVmsObj->FDispLog) { IPC_LOG_MESSAGE *pLog = &FLogMsg;//new IPC_LOG_MESSAGE; if (pLog) { pLog->Kind = eLOG_DATA; pLog->Flag = ASndRcv[0] == 'S' ? 1 : 2; pLog->Len = ALen > MAX_LOG_BUFFER ? MAX_LOG_BUFFER-1 : ALen; pLog->Tm = Now(); pLog->Type = 'C'; memset(pLog->Msg, 0x00, sizeof(pLog->Msg)); memcpy(pLog->Msg, (char*)AData, pLog->Len); pLog->Obj = (void*)FVmsObj; DWORD dwResult = 0; LRESULT lResult = SEND_LOGMSG(FrmVmsLog->Handle, WM_LOG_DISPLAY, (WPARAM)pLog, NULL, SMTO_NORMAL, 2000, dwResult); if (lResult == 0) { dwResult = GetLastError(); if (dwResult == ERROR_TIMEOUT) { } //SAFE_DELETE(pLog); } } } } catch(Exception &e) { } return result; } //--------------------------------------------------------------------------- int TVMSCThread::SysLogWrite(int ALogKind, char *AFmt, ...) { va_list ap; int cnt = 0; char szFmtData[MAX_LOG_BUFFER]; AnsiString sLogKind; int nStep = 0; if (!FLogFile) return cnt; bool bLog = false; switch(ALogKind) { case eLOG_INFO : bLog = FLogFile->FLogCfg.Info; sLogKind = " [INF] "; break; case eLOG_DATA : bLog = FLogFile->FLogCfg.Data; sLogKind = " [DAT] "; break; case eLOG_ERROR : bLog = FLogFile->FLogCfg.Error; sLogKind = " [ERR] "; break; case eLOG_WARNING: bLog = FLogFile->FLogCfg.Warning; sLogKind = " [WAN] "; break; case eLOG_DEBUG : bLog = FLogFile->FLogCfg.Debug; sLogKind = " [DBG] "; break; case eLOG_DETAIL : bLog = FLogFile->FLogCfg.Detail; sLogKind = " [DET] "; break; } if (!bLog) return -1; try { va_start(ap, AFmt); cnt = vsprintf(szFmtData, AFmt, ap); va_end(ap); FLogFile->LogWrite(NULL, ALogKind, szFmtData); IPC_LOG_MESSAGE *pLog = &FLogMsg;//new IPC_LOG_MESSAGE; if (pLog) { pLog->Kind = ALogKind; pLog->Flag = 0; pLog->Len = strlen(szFmtData); pLog->Tm = Now(); pLog->Type = 'C'; memset(pLog->Msg, 0x00, sizeof(pLog->Msg)); sprintf(pLog->Msg, "%s-CLI %s, %s", sLogKind.c_str(), VMSID.c_str(), szFmtData); pLog->Obj = (void*)FVmsObj; DWORD dwResult = 0; LRESULT lResult = SEND_LOGMSG(FrmSysLog->Handle, WM_LOG_DISPLAY, pLog, NULL, SMTO_NORMAL, 2000, dwResult); if (lResult == 0) { dwResult = GetLastError(); if (dwResult == ERROR_TIMEOUT) { } //SAFE_DELETE(pLog); } } if (FVmsObj->FDispLog) { IPC_LOG_MESSAGE *pLog2 = &FLogMsg;//new IPC_LOG_MESSAGE; if (pLog2) { pLog2->Kind = ALogKind; pLog2->Flag = 0; pLog2->Len = strlen(szFmtData); pLog2->Tm = Now(); pLog2->Type = 'C'; memset(pLog2->Msg, 0x00, sizeof(pLog2->Msg)); sprintf(pLog2->Msg, "%s-CLI %s, %s", sLogKind.c_str(), VMSID.c_str(), szFmtData); pLog2->Obj = (void*)FVmsObj; DWORD dwResult = 0; LRESULT lResult = SEND_LOGMSG(FrmVmsLog->Handle, WM_LOG_DISPLAY, pLog2, NULL, SMTO_NORMAL, 2000, dwResult); if (lResult == 0) { dwResult = GetLastError(); if (dwResult == ERROR_TIMEOUT) { } //SAFE_DELETE(pLog2); } } } } catch(Exception &e) { } return cnt; } //--------------------------------------------------------------------------- int TVMSCThread::LogWrite(int ALogKind, char *AFmt, ...) { va_list ap; int cnt = 0; char szFmtData[MAX_LOG_BUFFER]; AnsiString sLogKind; int nStep = 0; if (!FLogFile) return cnt; bool bLog = false; switch(ALogKind) { case eLOG_INFO : bLog = FLogFile->FLogCfg.Info; sLogKind = " [INF] "; break; case eLOG_DATA : bLog = FLogFile->FLogCfg.Data; sLogKind = " [DAT] "; break; case eLOG_ERROR : bLog = FLogFile->FLogCfg.Error; sLogKind = " [ERR] "; break; case eLOG_WARNING: bLog = FLogFile->FLogCfg.Warning; sLogKind = " [WAN] "; break; case eLOG_DEBUG : bLog = FLogFile->FLogCfg.Debug; sLogKind = " [DBG] "; break; case eLOG_DETAIL : bLog = FLogFile->FLogCfg.Detail; sLogKind = " [DET] "; break; } if (!bLog) return -1; try { va_start(ap, AFmt); cnt = vsprintf(szFmtData, AFmt, ap); va_end(ap); FLogFile->LogWrite(NULL, ALogKind, szFmtData); if (FVmsObj->FDispLog) { IPC_LOG_MESSAGE *pLog = &FLogMsg;//new IPC_LOG_MESSAGE; if (pLog) { pLog->Kind = ALogKind; pLog->Flag = 0; pLog->Len = strlen(szFmtData); pLog->Tm = Now(); pLog->Type = 'C'; memset(pLog->Msg, 0x00, sizeof(pLog->Msg)); sprintf(pLog->Msg, "%s-CLI %s, %s", sLogKind.c_str(), VMSID.c_str(), szFmtData); pLog->Obj = (void*)FVmsObj; DWORD dwResult = 0; LRESULT lResult = SEND_LOGMSG(FrmVmsLog->Handle, WM_LOG_DISPLAY, pLog, NULL, SMTO_NORMAL, 2000, dwResult); if (lResult == 0) { dwResult = GetLastError(); if (dwResult == ERROR_TIMEOUT) { } //SAFE_DELETE(pLog); } } } } catch(Exception &e) { } return cnt; } //---------------------------------------------------------------------------