?? ccdb.cpp
字號:
return ERR_BUS_PARAMSIZE;
}
//設置統計sql語句
swprintf(wcSql,L"select SceneID from SceneDevTable where SceneID = %d and DevID=%d",
*((int*)pstrReqParam->pBuf),*(((int*)pstrReqParam->pBuf)+1));
}
break;
case BUSINESS_SCENE:// 場景表
{//參數：房間ID、場景ID、場景名稱
if(pstrReqParam->nSize != (CC_SCENE_NAME_LEN+sizeof(int)))
{
return ERR_BUS_PARAMSIZE;
}
SumParamScene *pParamScene=(SumParamScene*)pstrReqParam->pBuf;
MultiByteToWideChar(CP_ACP,MB_PRECOMPOSED,(char*)pParamScene->SceneName,CC_SCENE_NAME_LEN,cwTemp,100);
ReplaceYinhao(cwTemp);
//設置統計sql語句
swprintf(wcSql,L"select SceneID from SceneTable where HouseID = %d and Name='%s'",
pParamScene->nHouseID,cwTemp);
}
break;
case BUSINESS_HOUSE:// 房間
{//參數：房間名稱
if(pstrReqParam->nSize != sizeof(SumParamHouse))
{
return ERR_BUS_PARAMSIZE;
}
SumParamHouse *pParamHouse=(SumParamHouse*)pstrReqParam->pBuf;
MultiByteToWideChar(CP_ACP,MB_PRECOMPOSED,pParamHouse->HouseName,CC_ROOM_NAME_LEN,cwTemp,100);
ReplaceYinhao(cwTemp);
//設置統計sql語句
swprintf(wcSql,L"select HouseID from HouseTable where Name='%s'",
cwTemp);
}
break;
case BUSINESS_CARD:// 卡號（用戶
{//參數：卡編號
if(pstrReqParam->nSize != sizeof(SumParamCard))
{
return ERR_BUS_PARAMSIZE;
}
SumParamCard *pParamCard=(SumParamCard*)pstrReqParam->pBuf;
MultiByteToWideChar(CP_ACP,MB_PRECOMPOSED,pParamCard->CardNum,CC_CARD_NUM_LEN,cwTemp,100);
ReplaceYinhao(cwTemp);
//設置統計sql語句
swprintf(wcSql,L"select CardID from CardTable where Number='%s'",
cwTemp);
}
break;
case BUSINESS_LOCKCODE://門磁碼表
{//參數：門磁碼
if(pstrReqParam->nSize != sizeof(SumParamLock))
{
return ERR_BUS_PARAMSIZE;
}
SumParamLock *pParamLock=(SumParamLock*)pstrReqParam->pBuf;
MultiByteToWideChar(CP_ACP,MB_PRECOMPOSED,pParamLock->LockName,CC_DOOR_MAGCODE_LEN,cwTemp,100);
ReplaceYinhao(cwTemp);
//設置統計sql語句
swprintf(wcSql,L"select LockID from LockCodeTable where Code='%s'",
cwTemp);
}
break;
case BUSINESS_PARTDEFENCE:
{//根據 檢查是否重復
int nsumsize=sizeof(SumParamPartDefence);
if(pstrReqParam->nSize != sizeof(SumParamPartDefence))
{
return ERR_BUS_PARAMSIZE;
}
SumParamPartDefence *pParam=(SumParamPartDefence*)pstrReqParam->pBuf;
//設置統計sql語句
swprintf(wcSql,L"select ID from PartDefenceTable where HouseID=%d \
and Type =%d and StartTime=%d and EndTime =%d",
pParam->nRoomId,pParam->cLookType,pParam->nStartTime,pParam->nEndTime);
}
break;
case BUSINESS_ADDRLIST_GROUP:
{//1026 //通訊簿分組表:【組名稱】和【組類型ID】
if(pstrReqParam->nSize != sizeof(SumParamGroup))
{
return ERR_BUS_PARAMSIZE;
}
SumParamGroup *pParam=(SumParamGroup*)pstrReqParam->pBuf;
MultiByteToWideChar(CP_ACP,MB_PRECOMPOSED,pParam->nGroupName,PHONEBOOKGROUP_NAME_LEN,cwTemp,100);
ReplaceYinhao(cwTemp);
//設置統計sql語句
swprintf(wcSql,L"select ID from AddrGroupTable where Type=%d and Name='%s'",pParam->nGroup,
cwTemp);
}
break;
case BUSINESS_ADDRLIST_PM:
{//1027 //普美用戶通訊錄:【組ID】和【姓名】
if(pstrReqParam->nSize != sizeof(SumParamPMBook))
{
return ERR_BUS_PARAMSIZE;
}
SumParamPMBook *pParam=(SumParamPMBook*)pstrReqParam->pBuf;
MultiByteToWideChar(CP_ACP,MB_PRECOMPOSED,pParam->szName,CC_NAME_LEN,cwTemp,100);
ReplaceYinhao(cwTemp);
//設置統計sql語句
swprintf(wcSql,L"select UserID from PMAddrListTable where GroupID=%d and Name='%s'",pParam->nGroupID,
cwTemp);
}
break;
case BUSINESS_ADDRLIST_PT:
{//1028 //普通用戶通訊錄:【組ID】和【昵稱】
if(pstrReqParam->nSize != sizeof(SumParamPTBook))
{
return ERR_BUS_PARAMSIZE;
}
SumParamPTBook *pParam=(SumParamPTBook*)pstrReqParam->pBuf;
MultiByteToWideChar(CP_ACP,MB_PRECOMPOSED,pParam->szName,CC_NAME_LEN,cwTemp,100);
ReplaceYinhao(cwTemp);
//設置統計sql語句
swprintf(wcSql,L"select UserID from PTAddrListTable where GroupID=%d and Name='%s'",pParam->nGroupID,
cwTemp);
}
break;
case BUSINESS_INFRAREFUN: // 紅外功能表
{
if(pstrReqParam->nSize != sizeof(int)*2)
{
return ERR_BUS_PARAMSIZE;
}
//設置統計sql語句
swprintf(wcSql,L"select Id from InfrareFunTable \
where FunID=%d and DevID=%d",
*((int*)pstrReqParam->pBuf),*(((int*)pstrReqParam->pBuf)+1));
}
break;
case BUSINESS_INFRAREFUNBIND:
{// //遙控器按鍵綁定:按鍵值和房間ID
if(pstrReqParam->nSize != sizeof(int)*2)
{
return ERR_BUS_PARAMSIZE;
}
//設置統計sql語句
swprintf(wcSql,L"select Idx from InfrareFunBindTable as a,DevTable as b \
where KeyVal=%d and ObjectType=%d and ObjectID=DevID and HouseID=%d \
UNION \
select Idx from InfrareFunBindTable as a,SceneTable as b \
where KeyVal=%d and ObjectType=%d and ObjectID=SceneID and HouseID=%d ",
*((int*)pstrReqParam->pBuf),REMOTEBIND_DEV,*(((int*)pstrReqParam->pBuf)+1),
*((int*)pstrReqParam->pBuf),REMOTEBIND_SCENE,*(((int*)pstrReqParam->pBuf)+1)
);
}
break;
default:
{
return ERR_BUS_MOTHEDNONE;
}
break;
}
if(!g_DataBase.OpenData())
{
return ERR_PROG_NOTOPEN;
}
int nCount=g_DataBase.CountSql(wcSql);
g_DataBase.CloseData();
return nCount;
}
break;
case ACTION_SUMGROUP: //統計指定父表ID（外鍵）的所有記錄數
{
WCHAR wcSql[300]=L"";
if(BusList[busindex].FKeyIndex<0)
return ERR_BUS_FOREIGNKEY;
if(pstrReqParam->nSize != sizeof(int))
return ERR_BUS_PARAMSIZE;
//設置統計sql語句
swprintf(wcSql,L"select * from %s where %s = %d",BusList[busindex].Name,(BusList[busindex].pBusFields + BusList[busindex].FKeyIndex)->NAME,
*((int *)pstrReqParam->pBuf)
);
if(!g_DataBase.OpenData())
{
return ERR_PROG_NOTOPEN;
}
int nCount=g_DataBase.CountSql(wcSql);
g_DataBase.CloseData();
return nCount;
}
break;
case ACTION_SUMALL: //統計所有記錄數（本地）
{
WCHAR wcSql[300]=L"";
if(BusList[busindex].FKeyIndex<0)
return ERR_BUS_FOREIGNKEY;
if(pstrReqParam->nSize != sizeof(int))
return ERR_BUS_PARAMSIZE;
//設置統計sql語句
swprintf(wcSql,L"select * from %s",BusList[busindex].Name);
// swprintf(wcSql,L"select %s from %s",BusList[busindex].pBusFields->NAME,BusList[busindex].Name);
if(!g_DataBase.OpenData())
{
return ERR_PROG_NOTOPEN;
}
int nCount=g_DataBase.CountSql(wcSql);
g_DataBase.CloseData();
return nCount;
}
break;
default:
{//單業務特殊功能處理
if(pOut !=NULL)
*pOut=NULL;
WCHAR cwTemp[100]=L"";
int nRet=0;
switch(pstrReqParam->nBusID)
{
case BUSINESS_CCINFO:
{
if(ACTION_MODIFY_CCINFOID==pstrReqParam->nMethod)
{//更改中控ID
if(pstrReqParam->nSize != sizeof(int) *2)
{
return ERR_BUS_PARAMSIZE;
}
swprintf(cwSql,L"Update CCInfoTable set CCID= %d where CCID=%d",
*(((int*)pstrReqParam->pBuf)+1),*(int*)pstrReqParam->pBuf);
if(!g_DataBase.OpenData())
{
return ERR_PROG_NOTOPEN;
}
BOOL bRet=g_DataBase.ExecuteSql(cwSql);
g_DataBase.CloseData();
if(bRet)
return ERR_BUS_SUCCESS;
else
return ERR_BUS_SQLEXE;
}else
{
return ERR_BUS_MOTHEDNONE;
}
}
break;
case BUSINESS_HOUSE:
{
if((ACTION_HOUSE_QUERYBYDEVTYPE==pstrReqParam->nMethod))
{//查詢房間具有人體紅外設備的房間信息 1011 21 改成根據參數指定的設備類型
if(pstrReqParam->nSize != sizeof(short) )
{
return ERR_BUS_PARAMSIZE;
}
swprintf(cwSql,L"select * from housetable where houseid in(select HouseID from devtable where Devtype=%d)",
*(short*)pstrReqParam->pBuf);
}else
{
return ERR_BUS_MOTHEDNONE;
}
}
break;
case BUSINESS_DEV:
{
if((ACTION_DEV_QUERYBYADDR==pstrReqParam->nMethod))
{//按地址查詢設備
if(pstrReqParam->nSize != sizeof(short) *2)
{
return ERR_BUS_PARAMSIZE;
}
swprintf(cwSql,L"select * from %s where DevAddr=%d and SysAddr=%d",BusList[busindex].Name,
*(short*)pstrReqParam->pBuf,*(((short*)pstrReqParam->pBuf)+1));
}else if(ACTION_DEV_QUERYBYDEVTYPE==pstrReqParam->nMethod)
{//根據設備類型查詢設備
if(pstrReqParam->nSize != sizeof(short))
{
return ERR_BUS_PARAMSIZE;
}
swprintf(cwSql,L"select * from DevTable where DevType =%d",*(short*)pstrReqParam->pBuf);
}else if(ACTION_DEV_QUERYBYBINDDEVID==pstrReqParam->nMethod)
{//根據虛設備ID查詢綁定的設備
if(pstrReqParam->nSize != sizeof(int))
{
return ERR_BUS_PARAMSIZE;
}
swprintf(cwSql,L"select * from DevTable where RealDevID =%d",*(int*)pstrReqParam->pBuf);
}else if(ACTION_DEV_UPDATE_ONLINE==pstrReqParam->nMethod )
{
if(pstrReqParam->nSize != sizeof(short)*2 +1)
{
return ERR_BUS_PARAMSIZE;
}
swprintf(cwSql,L"Update DevTable set IsOnLine=%d \
where (SysAddr=%d and DevAddr=%d) or \
DevID in (select virtual.DevId from DevTable as real,DevTable as virtual where real.SysAddr=%d and real.DevAddr=%d and real.DevID = virtual.RealDevID)",
*((BYTE*)pstrReqParam->pBuf+4),*(short*)pstrReqParam->pBuf,*(((short*)pstrReqParam->pBuf)+1),
*(short*)pstrReqParam->pBuf,*(((short*)pstrReqParam->pBuf)+1));
if(!g_DataBase.OpenData())
{
return ERR_PROG_NOTOPEN;
}
nRet=g_DataBase.ExecuteSql(cwSql);
g_DataBase.CloseData();
//發送同步消息
/* num=sizeof(BusToCmdList)/sizeof(BusToCmdList[0]);
for(i=0;i<num;i++)
{
if(BusToCmdList[i].nBus== pstrReqParam->nBusID)
break;
}
if(nRet && i <num && bSyn)
*/ if(nRet && bSyn)
{
#ifndef _USEBYLHL
struct devce_state_info DevInfo;
memset(&DevInfo,0,sizeof(struct devce_state_info));
DevInfo.shSysAddr = *(short*)pstrReqParam->pBuf;
DevInfo.shDevAddr =*(((short*)pstrReqParam->pBuf)+1);
DevInfo.stateType=0;
DevInfo.cOnLine=*((BYTE*)pstrReqParam->pBuf+4);
DLLSynFuntInterfaceBug(pstrReqParam->nBusID,SYS_ACTION_DEV_STATUS,(char*)pstrReqParam->pBuf,sizeof(short)*2,
(char*)&DevInfo,sizeof(struct devce_state_info));
#endif
}
if(nRet )
return ERR_BUS_SUCCESS;
else
return ERR_BUS_SQLEXE;
}
else if(ACTION_DEV_UPDATE_ENABLE==pstrReqParam->nMethod)
{
if(pstrReqParam->nSize != sizeof(short)*2 +1)
{
return ERR_BUS_PARAMSIZE;
}
swprintf(cwSql,L"Update DevTable set SysStatus=%d,Value=0 \
where (SysAddr=%d and DevAddr=%d) or \
DevID in (select virtual.DevId from DevTable as real,DevTable as virtual where real.SysAddr=%d and real.DevAddr=%d and real.DevID = virtual.RealDevID)",
*((BYTE*)pstrReqParam->pBuf+4),*(short*)pstrReqParam->pBuf,*(((short*)pstrReqParam->pBuf)+1),
*(short*)pstrReqParam->pBuf,*(((short*)pstrReqParam->pBuf)+1));
// wprintf(_T("----------------------sql=%s\n"),cwSql);
if(!g_DataBase.OpenData())
{
return ERR_PROG_NOTOPEN;
}
nRet=g_DataBase.ExecuteSql(cwSql);
g_DataBase.CloseData();
//發送同步消息
/* num=sizeof(BusToCmdList)/sizeof(BusToCmdList[0]);
for(i=0;i<num;i++)
{
if(BusToCmdList[i].nBus== pstrReqParam->nBusID)
break;
}
if(nRet && i <num && bSyn)
*/ if(nRet && bSyn)
{
#ifndef _USEBYLHL
struct devce_state_info DevInfo;
memset(&DevInfo,0,sizeof(struct devce_state_info));
DevInfo.shSysAddr = *(short*)pstrReqParam->pBuf;
DevInfo.shDevAddr =*(((short*)pstrReqParam->pBuf)+1);
DevInfo.stateType=2;
DevInfo.cStop=*((BYTE*)pstrReqParam->pBuf+4);
DLLSynFuntInterfaceBug(pstrReqParam->nBusID,SYS_ACTION_DEV_STATUS,(char*)pstrReqParam->pBuf,sizeof(short)*2,
(char*)&DevInfo,sizeof(struct devce_state_info));
#endif
}
if(nRet )
return ERR_BUS_SUCCESS;
else
return ERR_BUS_SQLEXE;
}
else if(ACTION_DEV_UPDATE_ENABLE_BYID==pstrReqParam->nMethod)
{
if(pstrReqParam->nSize != sizeof(int) +1)
{
return ERR_BUS_PARAMSIZE;
}
swprintf(cwSql,L"Update DevTable set SysStatus=%d,Value=0 \
where (DevID=%d) or \
DevID in (select virtual.DevId from DevTable as real,DevTable as virtual where real.DevID=%d and real.DevID = virtual.RealDevID)",
*((BYTE*)pstrReqParam->pBuf+4),*(int*)pstrReqParam->pBuf,
*(int*)pstrReqParam->pBuf);
// wprintf(_T("----------------------sql=%s\n"),cwSql);
if(!g_DataBase.OpenData())
{
return ERR_PROG_NOTOPEN;
}
nRet=g_DataBase.ExecuteSql(cwSql);
g_DataBase.CloseData();
//發送同步消息
/* num=sizeof(BusToCmdList)/sizeof(BusToCmdList[0]);
for(i=0;i<num;i++)
{
if(BusToCmdList[i].nBus== pstrReqParam->nBusID)
break;
}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -