luojie.rar_模拟汽车_汽车 游戏

// WorkStream.cpp: implementation of the CWorkStream class. // ////////////////////////////////////////////////////////////////////// #include "stdafx.h" #include "GFrame.h" #include "WorkStream.h" #include "MyMath.h" #ifdef _DEBUG #undef THIS_FILE static char THIS_FILE[]=__FILE__; #define new DEBUG_NEW #endif #ifdef _DEBUG #pragma comment(lib, "LIB/OpenGLD.lib") #else #pragma comment(lib, "LIB/OpenGL.lib") #endif ////////////////////////////////////////////////////////////////////// // Construction/Destruction ////////////////////////////////////////////////////////////////////// CWorkStream::CWorkStream() { m_iShowMode = 0; } CWorkStream::~CWorkStream() { } BOOL CWorkStream::InitStream() { switch(m_iShowMode) { case 0://local script { m_objCMainConfig.LoadActionScript(&m_dequeLocalActionScript); if(0)//生成脚本用,正式版本中自动被优化 { m_objCMainConfig.SaveActionScript(&m_dequeLocalActionScript); } CorrectActionScript();//补充不足的数据，仅仅用于简化部分脚本编写 } break; case 1://net { char cIP[20] = "\0", cPort[8] = "\0"; m_objCMainConfig.GetServerIP(cIP, cPort); if(!CClientMaster::Init(cIP, cPort))//第一次均返回FALSE { } } break; } return TRUE; } BOOL CWorkStream::SendStream() { if(GetSceneMode() >= 2)//编辑模式不处理外部动作流 return FALSE; m_objCMyCriticalSection[Type_CarSprite].Lock(); //流翻译为动作代码并发送 switch(m_iShowMode) { case 0://local script { LocalScriptStreamToActionStream(); } break; case 1://net { NetStreamToActionStream(); } break; } m_objCMyCriticalSection[Type_CarSprite].Unlock(); return TRUE; } BOOL CWorkStream::ReceiveStream() { switch(m_iShowMode) { case 0://local script InitStream()中已处理 { } break; case 1://net 已自动调用OnDataReceived，此处不处理 { } break; case 2://other { } break; default: return FALSE; } return TRUE; } BOOL CWorkStream::Init(HWND hWnd, int x, int y) { if(!CTSELReader::ImportTrackSerialFileFromRes()) { AfxMessageBox("轨道数据装载失败，可能是程序文件被病毒感染或者被非法篡改!"); return FALSE; } if(!m_objCMainConfig.Load()) { m_objCMainConfig.SetServerIP("127.0.0.1", "6669"); m_objCMainConfig.Save(); AfxMessageBox("配置数据[网络模块]装载失败，可能是配置文件被病毒感染或者被非法篡改!"); } SetThreadAffinityMask(::GetCurrentThread(), 0x00000001); m_iShowMode = m_objCMainConfig.GetShowMode(); SetShowMode(m_iShowMode); if(!InitStream()) { AfxMessageBox("工作流装载失败，可能是网络或者脚本数据错误!"); return FALSE; } CSceneMaster::SetTrackPhysicalLen(m_objCMainConfig.GetTrackPhysicalLen()); return CSceneMaster::Init(hWnd, x, y); } void CWorkStream::Close() { m_dequeNetCarInputStream.clear(); m_dequeLocalScriptInputStream.clear(); m_dequeLocalActionScript.clear(); //m_dequeLocalActionScript COpenGL::Close(); } void CWorkStream::SetSceneSize(int cx, int cy) { COpenGL::ChangeSize(cx, cy); } //接收网络数据 void CWorkStream::OnDataReceived(const LPBYTE lpBuffer, DWORD dwCount) { if(GetSceneMode() >= 2)//编辑模式不处理外部动作流 { return; } if(dwCount > 1024) { TRACE("Net package Size error! %d\n", dwCount); g_pObjCGlobal->g_objCTipInfo.SetTipInfo("网络数据包长度错误!", 1, 3000, RGB(255, 0, 0)); return; } USHORT usHeadCmd = 0; memcpy(&usHeadCmd, lpBuffer, sizeof(USHORT)); if(usHeadCmd < 1 || usHeadCmd > 5) { char cBuf[128] = "\0"; sprintf(cBuf, "收到未定义的命令头！[%d]", usHeadCmd); g_pObjCGlobal->g_objCTipInfo.SetTipInfo(cBuf, 1, 3000, RGB(255, 0, 0)); g_pObjCGlobal->g_objCTipInfo.MyTrace(1000, RGB(255, 0, 0), cBuf); TRACE("Net cmd error! %d\n", usHeadCmd); return; } switch(usHeadCmd) { case 1://轨道车数据 { TAG_NET_CAR_COMMUNICATE st = {0}; memcpy(&st.stTAG_NET_PACK, lpBuffer, sizeof(st.stTAG_NET_PACK)); if(st.stTAG_NET_PACK.iDataLenght != sizeof(TAG_PLCDATA)) { //非法包 g_pObjCGlobal->g_objCTipInfo.SetTipInfo("轨道车动作网络数据包校验错误!", 1, 3000, RGB(255, 0, 0)); } else { m_objCMyCriticalSection[Type_CarSprite].Lock(); m_dequeNetCarInputStream.push_back(st); m_objCMyCriticalSection[Type_CarSprite].Unlock(); } } break; case 2://横梁 { } break; case 3://门 { } break; case 4://动物 { } break; case 5://屏幕 { } break; default: ; } //print log file in here... } BOOL CWorkStream::LocalScriptStreamToActionStream() { for(ULONG ulIndex = 0; ulIndex < m_dequeLocalActionScript.size(); ulIndex ++) { for(ULONG ulSubID = 0; ulSubID < m_dequeLocalActionScript.at(ulIndex).dequeCarAction.size(); ulSubID++) { BOOL bUpdate = FALSE; ULONG ulID = m_dequeLocalActionScript.at(ulIndex).dequeCarAction.at(ulSubID).ulID_Bottom; //根据ID确定动作指示的车辆 CCarSprite::TAG_CAR_STATE st = {0}; for(ULONG ulCar = 0; ulCar < CCarSpriteMaster::GetCarNum(); ulCar++) { if(!CCarSpriteMaster::GetState(ulCar, st)) return FALSE; if(st.ulID == ulID) { break; } } if((st.stCarBottom.emActionState == ActionNullState) && m_dequeLocalActionScript.at(ulIndex).dequeCarAction.at(ulSubID).ulKeepMs_Bottom > 0)//上一个动作已执行完成 { if(DoubeEqual(m_dequeLocalActionScript.at(ulIndex).dequeCarAction.at(ulSubID).dSpeed_Bottom, 0.00000f, 0.00001f))// 0 不显示 1 刹车 2 前进 3 后退 { st.stCarBottom.iState = 1;//刹车 } else if(m_dequeLocalActionScript.at(ulIndex).dequeCarAction.at(ulSubID).dSpeed_Bottom > 0.00000f) { st.stCarBottom.iState = 2;//前 } else { st.stCarBottom.iState = 3;//后 } //st.ulID st.stCarBottom.dPhysicalLacation = m_dequeLocalActionScript.at(ulIndex).dequeCarAction.at(ulSubID).dPhysicalLacation_Bottom; st.stCarBottom.dSpeed = m_dequeLocalActionScript.at(ulIndex).dequeCarAction.at(ulSubID).dSpeed_Bottom; st.stCarBottom.stActionPreState_Parameter.ulKeepMs = m_dequeLocalActionScript.at(ulIndex).dequeCarAction.at(ulSubID).ulPreKeepMs_Bottom; st.stCarBottom.stActionExecuteState_Parameter.ulKeepMs = m_dequeLocalActionScript.at(ulIndex).dequeCarAction.at(ulSubID).ulKeepMs_Bottom; st.stCarBottom.stActionNextState_Parameter.ulKeepMs = m_dequeLocalActionScript.at(ulIndex).dequeCarAction.at(ulSubID).ulNextKeepMs_Bottom; st.stCarBottom.emActionState = ActionPreState;//启动 bUpdate = TRUE; } for(int iObj = 0; iObj < 3; iObj++) { if((st.stBody.stRotate.stActionXYZ[iObj].emActionState == ActionNullState) && m_dequeLocalActionScript.at(ulIndex).dequeCarAction.at(ulSubID).ulKeepMs_Body_Rotate[iObj] > 0)//上一个动作已执行完成 { if(iObj == 0)//X { st.stBody.stRotate.dAngleX = m_dequeLocalActionScript.at(ulIndex).dequeCarAction.at(ulSubID).dAngleX_Body; st.stBody.stRotate.dAngleRateX = m_dequeLocalActionScript.at(ulIndex).dequeCarAction.at(ulSubID).dAngleRateX_Body; } else if(iObj == 1)//Y { TRACE("%lf\n", m_dequeLocalActionScript.at(ulIndex).dequeCarAction.at(ulSubID).dAngleY_Body); st.stBody.stRotate.dAngleY = m_dequeLocalActionScript.at(ulIndex).dequeCarAction.at(ulSubID).dAngleY_Body; st.stBody.stRotate.dAngleRateY = m_dequeLocalActionScript.at(ulIndex).dequeCarAction.at(ulSubID).dAngleRateY_Body; } else//Z { st.stBody.stRotate.dAngleZ = m_dequeLocalActionScript.at(ulIndex).dequeCarAction.at(ulSubID).dAngleZ_Body; st.stBody.stRotate.dAngleRateZ = m_dequeLocalActionScript.at(ulIndex).dequeCarAction.at(ulSubID).dAngleRateZ_Body; } st.stBody.stRotate.stActionXYZ[iObj].stActionPreState_Par