496 lines
14 KiB
C++
496 lines
14 KiB
C++
//---------------------------------------------------------------------------
|
|
#include <vcl.h>
|
|
#include <stdio.h>
|
|
#include <time.h>
|
|
#pragma hdrstop
|
|
|
|
#include "BacDPThread.h"
|
|
#include "GlobalUnit.h"
|
|
#include "GameUnit.h"
|
|
#include "UtilityUnit.h"
|
|
#include "TableUnit.h"
|
|
//#include "ActiveFormUnit.h"
|
|
//---------------------------------------------------------------------------
|
|
#pragma package(smart_init)
|
|
|
|
//软件过期时间
|
|
#define TM_ABORT 125000
|
|
void __fastcall WriteData( char* msg )
|
|
{
|
|
SYSTEMTIME st;
|
|
GetLocalTime(&st);
|
|
|
|
char szDataFile[256];
|
|
sprintf( szDataFile, "%s/data/%04d%02d%02d.txt", g_AppPath, st.wYear, st.wMonth, st.wDay);
|
|
|
|
// FILE* fp = NULL;
|
|
// if(!FileExists(szDataFile)){
|
|
// fp = fopen(szDataFile, "w");
|
|
// if(fp)
|
|
// fprintf( fp, "时间,台桌,手数,结果\n" );
|
|
// }
|
|
// else{
|
|
// fp = fopen(szDataFile, "a");
|
|
// }
|
|
FILE* fp = fopen(szDataFile, "r+");
|
|
if(!fp){
|
|
fp = fopen(szDataFile, "w");
|
|
if(fp)
|
|
fprintf( fp, "时间,台桌,手数,结果\n" );
|
|
}
|
|
else
|
|
fseek(fp, 0, SEEK_END);
|
|
|
|
if( fp ){
|
|
fprintf( fp, "%02d:%02d:%02d,%s\n", st.wHour, st.wMinute, st.wSecond, msg );
|
|
fclose( fp );
|
|
}
|
|
else{
|
|
g_bBacData = false;
|
|
ShowMessage("导出数据失败! errno=" + IntToStr((int)GetLastError()));
|
|
}
|
|
}
|
|
//---------------------------------------------------------------------------
|
|
|
|
/////////////////////////////////////////////////////////////////////////////
|
|
// TBetWayThread
|
|
__fastcall TDataParseThread::TDataParseThread()
|
|
{
|
|
m_hDataEvent = CreateEvent(NULL, FALSE, TRUE, NULL);
|
|
|
|
// m_tmGST = 0;
|
|
// m_tmExpire = GetCompileTime() + 30 * 86400; //编译时间后30天过期
|
|
}
|
|
//---------------------------------------------------------------------------
|
|
|
|
__fastcall TDataParseThread::~TDataParseThread()
|
|
{
|
|
CloseHandle( m_hDataEvent );
|
|
}
|
|
//---------------------------------------------------------------------------
|
|
|
|
void __fastcall TDataParseThread::Reset()
|
|
{
|
|
WaitForSingleObject(m_hDataEvent, 5000);
|
|
m_aData.clear();
|
|
SetEvent(m_hDataEvent);
|
|
}
|
|
//---------------------------------------------------------------------------
|
|
|
|
void __fastcall TDataParseThread::ParseData(String sData)
|
|
{
|
|
WaitForSingleObject(m_hDataEvent, 5000);
|
|
m_aData.push_back(sData);
|
|
SetEvent(m_hDataEvent);
|
|
|
|
Suspended = false;
|
|
}
|
|
//---------------------------------------------------------------------------
|
|
|
|
void __fastcall TDataParseThread::Execute()
|
|
{
|
|
SetThreadExecutionState(ES_CONTINUOUS | ES_SYSTEM_REQUIRED); //关闭系统休眠
|
|
|
|
while( !Terminated ){
|
|
while(m_aData.size()>0){
|
|
String sData = m_aData[0];
|
|
// if(sData.Length()<3){
|
|
// WaitForSingleObject(m_hDataEvent, 5000);
|
|
// m_aData.erase(m_aData.begin());
|
|
// SetEvent(m_hDataEvent);
|
|
// continue;
|
|
// }
|
|
// DebugPrint(((AnsiString)sData).c_str());
|
|
|
|
TStringDynArray arr = SplitString( sData, "|" );
|
|
if(arr.Length<2){
|
|
WaitForSingleObject(m_hDataEvent, 5000);
|
|
m_aData.erase(m_aData.begin());
|
|
SetEvent(m_hDataEvent);
|
|
continue;
|
|
}
|
|
|
|
int iType = arr[0].ToInt();
|
|
if( iType==0 ){ //连接异常断开
|
|
DebugPrint("连接异常断开");
|
|
int reason = arr[1].ToInt();
|
|
PostMessage( Application->MainFormHandle, UM_WEBDEAD, reason, 0 );
|
|
}
|
|
else if( iType==1 ){ //初始化所有台桌
|
|
DebugPrint("!!! init all tables");
|
|
g_aGames.Init(arr[1]);
|
|
PostMessage( Application->MainFormHandle, UM_ADDTABLE, 0, 0 );
|
|
}
|
|
else if( iType==2 ){ //台桌Roadmap
|
|
if(!g_aGames.empty() && arr[1].Length()){
|
|
int iG = Vid2Gid(arr[1]);
|
|
TGame* pGame = NULL;
|
|
int ind = g_aGames.FindGame(iG, pGame);
|
|
|
|
if(!pGame && iG>0){
|
|
pGame = g_aGames.NewGame(iG, arr[g_iPlatform==PF_PA ? 1 : 2], ind);
|
|
PostMessage( Application->MainFormHandle, UM_ADDTABLE, ind, (long)pGame );
|
|
}
|
|
|
|
if(pGame){
|
|
int oldSize = pGame->aRes.size(),
|
|
newSize = arr[3].Length();
|
|
|
|
if(oldSize!=newSize && oldSize!=newSize+1){
|
|
#ifdef _DEBUG
|
|
if(newSize && oldSize && (oldSize>newSize || oldSize<newSize-1)){
|
|
char res[128];
|
|
for(int i=0; i<oldSize; i++){
|
|
res[i] = pGame->aRes[i] + '0';
|
|
}
|
|
res[oldSize] = 0;
|
|
|
|
DebugPrint("!!! %s road size %d -> %d with map: %s -> %s",
|
|
((AnsiString)pGame->vid).c_str(),
|
|
// ((AnsiString)arr[1]).c_str(),
|
|
oldSize, newSize, res,
|
|
((AnsiString)arr[3]).c_str());
|
|
}
|
|
#endif
|
|
if(g_bGameOn && pGame->bRun)
|
|
pGame->AutoBetOff();
|
|
|
|
if(newSize==oldSize+1){
|
|
int wt = arr[3][newSize]-'0';
|
|
if(wt==0) wt = 3;
|
|
|
|
pGame->aRes.push_back(wt);
|
|
pGame->winCount[wt-1]++;
|
|
pGame->BuildRoadmap(wt);
|
|
}
|
|
else{
|
|
pGame->ClearResults();
|
|
|
|
for(int i=1; i<=newSize; i++){
|
|
int wt = arr[3][i]-'0';
|
|
if(wt==0) wt = 3;
|
|
|
|
pGame->aRes.push_back(wt);
|
|
pGame->winCount[wt-1]++;
|
|
pGame->BuildRoadmap(wt);
|
|
}
|
|
}
|
|
|
|
bool bUpdateRoad = true;
|
|
if(pGame->gmstatus==12){ //维护台桌
|
|
if(oldSize && !newSize) //新局
|
|
pGame->AutoBetOn(); //台桌维护中无法正常处理shuffle状态，调用该接口显示和处理新局
|
|
}
|
|
else{ //正常台桌
|
|
pGame->gmstatus = 0; //设置结算状态，避免重复计算
|
|
// pGame->gmcode = "";
|
|
|
|
if(oldSize<newSize){
|
|
pGame->HandleResult(oldSize+1==newSize ? 0 : 1); //0=正常处理 1=异常处理
|
|
bUpdateRoad = false;
|
|
}
|
|
}
|
|
|
|
if(bUpdateRoad && pGame->hTable)
|
|
PostMessage(pGame->hTable, UM_TAB_UPDATE, UPDATE_ROAD, 0);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
else if( iType==3 ){ //台桌状态
|
|
// 3 | vid | gmcode | wintype(timeout)
|
|
if(!g_aGames.empty() && arr.Length>=4){
|
|
int iG = Vid2Gid(arr[1]);
|
|
TGame* pGame = NULL;
|
|
int ind = g_aGames.FindGame(iG, pGame);
|
|
|
|
if(!pGame && iG>0){
|
|
pGame = g_aGames.NewGame(iG, arr[g_iPlatform==PF_PA ? 1 : 2], ind);
|
|
PostMessage( Application->MainFormHandle, UM_ADDTABLE, ind, (long)pGame );
|
|
}
|
|
|
|
if( pGame ){
|
|
String gmcode = arr[3];
|
|
int status = arr[4].ToInt();
|
|
bool bNewStatus = pGame->gmstatus != status,
|
|
bNewCode = pGame->gmcode != gmcode;
|
|
|
|
if(!bNewCode && bNewStatus || bNewCode && (g_iPlatform!=PF_PA
|
|
|| gmcode=="" || gmcode > pGame->gmcode)){
|
|
#ifdef _DEBUG
|
|
if( bNewCode && status!=1 && status<11 && (g_iPlatform!=PF_AB || status!=0) && pGame->gmcode.Length()){
|
|
DebugPrint("!!! %s gmcode %s -> %s with status: %d",
|
|
((AnsiString)pGame->vid).c_str(),
|
|
// ((AnsiString)arr[1]).c_str(),
|
|
((AnsiString)pGame->gmcode).c_str(),
|
|
((AnsiString)gmcode).c_str(),
|
|
status);
|
|
}
|
|
#endif
|
|
if(bNewCode)
|
|
pGame->gmcode = gmcode;
|
|
|
|
// pGame->timeout = 0;
|
|
|
|
if(bNewStatus && pGame->gmstatus==1){
|
|
pGame->ManualBetOff();
|
|
|
|
if(g_bGameOn && pGame->bRun)
|
|
pGame->AutoBetOff();
|
|
}
|
|
|
|
if(status==0 && !bNewCode){ //结算
|
|
#ifdef _DEBUG
|
|
if(pGame->gmstatus!=2 && (g_iPlatform!=PF_AB || pGame->gmstatus!=11))
|
|
DebugPrint("!!! %s status %d -> %d",
|
|
((AnsiString)pGame->vid).c_str(),
|
|
// ((AnsiString)arr[1]).c_str(),
|
|
pGame->gmstatus, status);
|
|
#endif
|
|
pGame->gmstatus = status;
|
|
|
|
if(arr.Length>=8){ //DB特殊处理
|
|
if(arr[6].Length()){
|
|
pGame->bcard = UnifyCard(arr[6]);
|
|
pGame->pcard = UnifyCard(arr[7]);
|
|
}
|
|
else
|
|
pGame->bcard = pGame->pcard = "";
|
|
}
|
|
|
|
int wt = 0;
|
|
if(arr.Length>=6 && arr[5].Length()){
|
|
wt = arr[5][1]-'0';
|
|
if(wt==0) wt = 3;
|
|
}
|
|
|
|
if(wt>0){
|
|
pGame->aRes.push_back(wt);
|
|
pGame->winCount[wt-1]++;
|
|
pGame->BuildRoadmap(wt);
|
|
pGame->HandleResult();
|
|
|
|
if(g_bBacData){
|
|
char data[128];
|
|
sprintf(data, "%s,%d,%s",
|
|
((AnsiString)arr[g_iPlatform==PF_PA ? 1 : 2]).c_str(),
|
|
pGame->aRes.size(), wt==1 ? "庄" : wt==2 ? "闲" : "和");
|
|
WriteData( data );
|
|
}
|
|
}
|
|
}
|
|
else if(status==1 && bNewStatus){// && pGame->gmstatus!=2){ //开始下注
|
|
#ifdef _DEBUG
|
|
if(pGame->gmstatus!=0 && pGame->gmstatus<11)
|
|
DebugPrint("!!! %s status %d -> %d",
|
|
((AnsiString)pGame->vid).c_str(),
|
|
// ((AnsiString)arr[1]).c_str(),
|
|
pGame->gmstatus, status);
|
|
#endif
|
|
if(bNewStatus && bNewCode && pGame->iState==ST_BETTED){
|
|
DebugPrint("!!! %s status %d -> %d with betted",
|
|
((AnsiString)pGame->vid).c_str(),
|
|
// ((AnsiString)arr[1]).c_str(),
|
|
pGame->gmstatus, status);
|
|
pGame->HandleResult(2);
|
|
}
|
|
|
|
pGame->gmstatus = status;
|
|
|
|
pGame->timeout = g_iPlatform==PF_AB ? pGame->countdown
|
|
: g_iPlatform==PF_DB ? arr[5].ToInt() / 1000
|
|
: arr[5].ToInt();
|
|
pGame->AutoBetOn();
|
|
}
|
|
else if(status==2 && !bNewCode){// && pGame->gmstatus==1 ){ //开牌中
|
|
#ifdef _DEBUG
|
|
if(pGame->gmstatus!=1)
|
|
DebugPrint("!!! %s status %d -> %d",
|
|
((AnsiString)pGame->vid).c_str(),
|
|
// ((AnsiString)arr[1]).c_str(),
|
|
pGame->gmstatus, status);
|
|
#endif
|
|
pGame->gmstatus = status;
|
|
|
|
if(pGame->iState==ST_BETTED)
|
|
pGame->timeout = -1; //开始计算超时
|
|
|
|
pGame->bcard = pGame->pcard = "";
|
|
}
|
|
else if((status==11 || status==12) && bNewStatus){ //洗牌/维护
|
|
if(pGame->iState==ST_BETTED || pGame->iState==ST_EXPIRED){ //超时
|
|
DebugPrint("!!! %s status %d -> %d with betted",
|
|
((AnsiString)pGame->vid).c_str(),
|
|
// ((AnsiString)arr[1]).c_str(),
|
|
pGame->gmstatus, status);
|
|
|
|
pGame->HandleResult(status==12 ? 3 : 2);
|
|
}
|
|
|
|
pGame->gmstatus = status;
|
|
|
|
if(status==11){
|
|
pGame->Shuffle();
|
|
|
|
if(g_bBacData){
|
|
char data[128];
|
|
sprintf(data, "%s,,%s",
|
|
((AnsiString)arr[g_iPlatform==PF_PA ? 1 : 2]).c_str(),
|
|
"洗牌");
|
|
WriteData( data );
|
|
}
|
|
}
|
|
else{
|
|
pGame->iState = ST_INIT;
|
|
#ifdef _DEBUG
|
|
DebugPrint("!!! %s 台桌维护中", ((AnsiString)pGame->vid).c_str());//, ((AnsiString)arr[1]).c_str());
|
|
SendMessage( Application->MainFormHandle, UM_RESTORE, 0, 0 );
|
|
#endif
|
|
}
|
|
}
|
|
|
|
if(pGame->hTable)
|
|
PostMessage(pGame->hTable, UM_TAB_UPDATE, UPDATE_STATUS, 0);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
else if(iType==4){ //多台状态
|
|
//4 | e.payload.vid
|
|
DebugPrint("Enter HALL: %s", ((AnsiString)arr[1]).c_str());
|
|
|
|
int tab = 2;
|
|
|
|
if(g_iPlatform==PF_PA){
|
|
tab = arr[1]=="LINK" ? 1 : arr[1]=="LOBB" ? 0 : 2;
|
|
}
|
|
else if(g_iPlatform==PF_AB){
|
|
int hId = arr[1].ToInt();
|
|
tab = hId==102 ? 1 : hId==100 ? 0 : 2;
|
|
}
|
|
else if(g_iPlatform==PF_DB){
|
|
int hId = arr[1].ToInt();
|
|
tab = hId==2 ? 1 : hId==0 ? 0 : 2;
|
|
}
|
|
|
|
PostMessage(Application->MainFormHandle, UM_ENTER_TABLE, tab, 0);
|
|
}
|
|
else if(iType==5){ //账户余额
|
|
//5 | e.val
|
|
double amo;
|
|
if(TryStrToFloat(arr[1], amo)){
|
|
if(!(g_bTesting && g_settings.bSimAccOn)){
|
|
g_fBalance = amo;
|
|
PostMessage(Application->MainFormHandle, UM_STATE_UPDATE, STATE_BALANCE, 0);
|
|
}
|
|
}
|
|
}
|
|
else if(iType==6){ //下注反馈
|
|
//6 | vid | retCode | gmcode | 庄 | 闲 | 平
|
|
if(!g_aGames.empty() && arr[1].Length()){
|
|
int iG = Vid2Gid(arr[1]);
|
|
TGame* pGame = NULL;
|
|
int ind = g_aGames.FindGame(iG, pGame);
|
|
|
|
if(pGame && pGame->gmcode==arr[3]){
|
|
int chips[3] = {0};
|
|
chips[0] = arr[4].ToInt();
|
|
chips[1] = arr[5].ToInt();
|
|
chips[2] = arr[6].ToInt();
|
|
|
|
int retCode = arr[2].ToInt();
|
|
|
|
if(retCode!=0){
|
|
if(g_iPlatform==PF_AB) //欧博错误码转换
|
|
retCode = retCode==101 ? 10 //限红低
|
|
: retCode==102 ? 11 //限红高
|
|
: retCode==103 || retCode==100015 || retCode==6044 ? 25 //超时
|
|
: retCode==10101 || retCode==6035 || retCode==6042 ? 26 //余额不足
|
|
: -1;
|
|
else if(g_iPlatform==PF_DB) //多宝错误码转换
|
|
retCode = retCode==210010 ? 10 //限红低
|
|
: retCode==220030 ? 11 //限红高
|
|
: retCode==220004 || retCode==220006 || retCode==110041 ? 25 //超时
|
|
: retCode==10469 || retCode==20126 ? 26 //余额不足
|
|
: retCode;
|
|
}
|
|
|
|
pGame->BetResp(retCode, chips);
|
|
}
|
|
}
|
|
}
|
|
else if(iType==7){ //限额
|
|
//7 | min | max
|
|
int minBet, maxBet;
|
|
if(TryStrToInt(arr[1], minBet) && TryStrToInt(arr[2], maxBet)){
|
|
if(minBet!=g_MinOnBet || maxBet!=g_MaxOnBet){
|
|
g_MinOnBet = minBet;
|
|
g_MaxOnBet = maxBet;
|
|
|
|
PostMessage(Application->MainFormHandle, UM_STATE_UPDATE, STATE_LIMIT, 0);
|
|
}
|
|
}
|
|
}
|
|
else if(iType==8){ //倒计时
|
|
//8 | countdownList ABG专用
|
|
if(!g_aGames.empty() && arr[1].Length()){
|
|
g_aGames.SetCountDown(arr[1]);
|
|
}
|
|
}
|
|
else if(iType==9){ //翻牌
|
|
//9 | gid | gmcode | bcard | pcard
|
|
if(!g_aGames.empty() && !arr[1].IsEmpty() && (!arr[3].IsEmpty() || !arr[4].IsEmpty())){
|
|
int iG = Vid2Gid(arr[1]);
|
|
TGame* pGame = NULL;
|
|
int ind = g_aGames.FindGame(iG, pGame);
|
|
|
|
if(pGame && pGame->gmstatus==2 && pGame->gmcode==arr[2]){
|
|
pGame->bcard = UnifyCard(arr[3]);
|
|
pGame->pcard = UnifyCard(arr[4]);
|
|
|
|
if(pGame->hTable)
|
|
PostMessage(pGame->hTable, UM_TAB_UPDATE, UPDATE_STATUS, 0);
|
|
|
|
if(pGame->iState==ST_BETTED)
|
|
pGame->timeout = -1; //重新计算超时
|
|
}
|
|
}
|
|
}
|
|
// else if(iType==10){ //撤销注单
|
|
// //10 | gid | gmcode
|
|
// if(!g_aGames.empty() && arr[1].Length()){
|
|
// int iG = Vid2Gid(arr[1]);
|
|
// TGame* pGame = NULL;
|
|
// int ind = g_aGames.FindGame(iG, pGame);
|
|
//
|
|
// if(pGame && pGame->gmcode==arr[2]){
|
|
// DebugPrint("!!! %s 撤销注单 with status: %d",
|
|
// ((AnsiString)pGame->vid).c_str(),
|
|
//// ((AnsiString)arr[1]).c_str(),
|
|
// pGame->gmstatus);
|
|
// pGame->gmstatus = 0;
|
|
// pGame->HandleResult(3);
|
|
// }
|
|
// }
|
|
// }
|
|
|
|
m_aData[0] = "";
|
|
|
|
if( Terminated )
|
|
break;
|
|
|
|
WaitForSingleObject(m_hDataEvent, 5000);
|
|
m_aData.erase(m_aData.begin());
|
|
SetEvent(m_hDataEvent);
|
|
}
|
|
|
|
// 等待数据
|
|
if( !Terminated )
|
|
Suspended = true;
|
|
};
|
|
|
|
SetThreadExecutionState( ES_CONTINUOUS );//打开系统休眠
|
|
}
|
|
//---------------------------------------------------------------------------
|
|
|