337 lines
7.3 KiB
C
337 lines
7.3 KiB
C
#include "script.h"
|
||
|
||
//打开实时数据库
|
||
int OpenRamRt()
|
||
{
|
||
#ifdef OS_WIN
|
||
char chRamName[30] ;
|
||
HANDLE hFile;
|
||
HANDLE hMapFile = 0;
|
||
LPVOID lpMapAddress = 0;
|
||
strcpy( chRamName, "RAMRT" );
|
||
|
||
if ( lpMapAddress ) UnmapViewOfFile( lpMapAddress );
|
||
if ( hMapFile ) CloseHandle( hMapFile );
|
||
|
||
hFile = (HANDLE) 0xFFFFFFFF ;
|
||
|
||
hMapFile = CreateFileMapping( hFile, NULL, PAGE_READWRITE, 0, STATION_SIZE , (LPCTSTR)chRamName );
|
||
if ( hMapFile == NULL ){
|
||
lpMapAddress = NULL;
|
||
return 0;
|
||
}
|
||
lpMapAddress = MapViewOfFile( hMapFile,FILE_MAP_ALL_ACCESS,0,0,0 );
|
||
pSysItem = ( double * )lpMapAddress ;
|
||
pStation = ( StructStation * )( ( double * )lpMapAddress + MAX_SYSITEM ) ;
|
||
return 1 ;
|
||
#endif
|
||
|
||
#ifdef OS_UNIX
|
||
int shmid ;
|
||
void *shmptr ;
|
||
|
||
if((shmid = shmget( SHMDBKEYRTRAM_RT , STATION_SIZE , SHM_MODE ) ) < 0 ){
|
||
return 0 ;
|
||
}
|
||
shmptr = shmat( shmid, 0, 0 ) ;
|
||
|
||
if ( shmptr == (void*) -1 ) {
|
||
return 0 ;
|
||
}
|
||
|
||
pSysItem = ( double * )shmptr ;
|
||
pStation = ( StructStation * )( ( double * )shmptr + MAX_SYSITEM );
|
||
return 1 ;
|
||
#endif
|
||
}
|
||
|
||
//延时函数
|
||
void waitForMillisec(int millisec)
|
||
{
|
||
#ifdef OS_WIN
|
||
Sleep(millisec);
|
||
#endif
|
||
|
||
#ifdef OS_UNIX
|
||
usleep(millisec*1000);
|
||
#endif
|
||
}
|
||
|
||
//获取实时数据库对应id的数值
|
||
double GetItemValue( int iStationid , int id )
|
||
{
|
||
if( bEmbed ) iStationid = 0 ;
|
||
StructStation * pStation1 ;
|
||
pStation1 = pStation + iStationid;
|
||
|
||
if ( id >= MAX_NUM )
|
||
return 0;
|
||
else
|
||
return pStation1->DataValue[ id ].dValue ;
|
||
}
|
||
|
||
//获取实时数据库对应id的数据结构体信息
|
||
StructData* GetItem(int iStationid,int id)
|
||
{
|
||
if( bEmbed ) iStationid = 0 ;
|
||
StructStation * pStation1 ;
|
||
pStation1 = pStation + iStationid;
|
||
|
||
if ( id >= MAX_NUM )
|
||
return 0;
|
||
else
|
||
return &pStation1->DataValue[ id ] ;
|
||
}
|
||
|
||
//获取实时数据库对应id的数据状态
|
||
char GetItemChangeState( int iStationid, int id )
|
||
{
|
||
if( bEmbed ) iStationid = 0 ;
|
||
StructStation * pStation1 ;
|
||
pStation1 = pStation + iStationid;
|
||
|
||
if ( id >= MAX_NUM )
|
||
return 0;
|
||
else
|
||
return pStation1->DataValue[ id ].bChangeState ;
|
||
}
|
||
|
||
//设置实时数据库对应id的数值
|
||
void SetItemValue( int iStationid , int id , double dValue )
|
||
{
|
||
if( bEmbed ) iStationid = 0 ;
|
||
StructStation * pStation1 ;
|
||
pStation1 = pStation + iStationid;
|
||
|
||
if ( id >= MAX_NUM ) return ;
|
||
|
||
pStation1->DataValue[id].dValue = dValue ;
|
||
}
|
||
|
||
//获取开出串的信息
|
||
StructKcData *GetKcData( int iStationid )
|
||
{
|
||
if( bEmbed ) iStationid = 0 ;
|
||
StructStation * pStation1 ;
|
||
pStation1 = pStation + iStationid ;
|
||
|
||
return &pStation1->DataKC;
|
||
}
|
||
|
||
//获取控制下发标志的状态
|
||
int GetKcFlag( int iStationid )
|
||
{
|
||
if( bEmbed ) iStationid = 0 ;
|
||
StructStation * pStation1 ;
|
||
pStation1 = pStation + iStationid ;
|
||
|
||
return pStation1->DataKCFlag;
|
||
}
|
||
|
||
//设置实时数据库对应id的数据状态
|
||
void SetDataState(int iStationid, int id, char bAlarm , char bChangeState)
|
||
{
|
||
if( bEmbed ) iStationid = 0 ;
|
||
StructStation * pStation1 ;
|
||
pStation1 = pStation + iStationid;
|
||
|
||
if ( id >= MAX_NUM ) return ;
|
||
|
||
pStation1->DataValue[id].bAlarm = bAlarm ;
|
||
pStation1->DataValue[id].bChangeState = bChangeState ;
|
||
}
|
||
|
||
|
||
//设置控制命令标志
|
||
void SetKcFlag(int iStationid, int flag)
|
||
{
|
||
if( bEmbed ) iStationid = 0 ;
|
||
StructStation * pStation1 ;
|
||
pStation1 = pStation + iStationid;
|
||
|
||
pStation1->DataKCFlag = flag;
|
||
}
|
||
|
||
//设置控制串 no为数据的id，data下发信息
|
||
void SetKcData(int iStationid, int no , char *data)
|
||
{
|
||
if( bEmbed ) iStationid = 0 ;
|
||
StructStation * pStation1 ;
|
||
pStation1 = pStation + iStationid;
|
||
|
||
pStation1->DataKC.kcNo = no;
|
||
// pStation1->DataKC.dataKC = data;
|
||
memset(&pStation1->DataKC.dataKC,0,sizeof(pStation1->DataKC.dataKC));
|
||
memcpy(pStation1->DataKC.dataKC, data, strlen(data));
|
||
printf("dataKc = %s\n, data = %s\n",pStation1->DataKC.dataKC, data);
|
||
}
|
||
|
||
|
||
//清除控制数据
|
||
void SetKcClear(int iStationid,int flag)
|
||
{
|
||
if( bEmbed ) iStationid = 0 ;
|
||
StructStation * pStation1 ;
|
||
pStation1 = pStation + iStationid;
|
||
|
||
if(!flag){
|
||
char data[200] = {0} ;
|
||
pStation1->DataKCFlag = flag ;
|
||
strcpy(pStation1->DataKC.dataKC,data);
|
||
}
|
||
}
|
||
|
||
//设置对应序号结构体信息
|
||
void SetStruct(int iNum,char *chMsg)
|
||
{
|
||
int iStationid = 0 ;
|
||
if( bEmbed ) iStationid = 0 ;
|
||
StructStation * pStation1 ;
|
||
pStation1 = pStation + iStationid;
|
||
|
||
strcpy(pStation1->chStruct[iNum],chMsg);
|
||
}
|
||
|
||
//设置结构体条数
|
||
void SetStructNum(int iStructNum)
|
||
{
|
||
int iStationid = 0 ;
|
||
if( bEmbed ) iStationid = 0 ;
|
||
StructStation * pStation1 ;
|
||
pStation1 = pStation + iStationid;
|
||
|
||
pStation1->StructNum = iStructNum;
|
||
}
|
||
|
||
//设置上传结构体信息
|
||
void SetStructUp(int iNum,char *chMsg)
|
||
{
|
||
int iStationid = 0 ;
|
||
if( bEmbed ) iStationid = 0 ;
|
||
StructStation * pStation1 ;
|
||
pStation1 = pStation + iStationid;
|
||
|
||
strcpy(pStation1->chStructUp[iNum],chMsg);
|
||
}
|
||
|
||
//设置上传结构体条数
|
||
void SetStructUpNum(int iStructNum)
|
||
{
|
||
int iStationid = 0 ;
|
||
if( bEmbed ) iStationid = 0 ;
|
||
StructStation * pStation1 ;
|
||
pStation1 = pStation + iStationid;
|
||
|
||
pStation1->StructUpNum = iStructNum;
|
||
}
|
||
|
||
//设置下传结构体信息
|
||
void SetStructDown(int iNum, char *chMsg)
|
||
{
|
||
int iStationid = 0 ;
|
||
if( bEmbed ) iStationid = 0 ;
|
||
StructStation * pStation1 ;
|
||
pStation1 = pStation + iStationid;
|
||
|
||
strcpy(pStation1->chStructDown[iNum],chMsg);
|
||
}
|
||
|
||
//设置下传结构体条数
|
||
void SetStructDownNum(int iProg ,int iNum)
|
||
{
|
||
int iStationid = 0 ;
|
||
if( bEmbed ) iStationid = 0 ;
|
||
StructStation * pStation1 ;
|
||
pStation1 = pStation + iStationid;
|
||
|
||
pStation1->StructDownProg = iProg;
|
||
pStation1->StructDownNum = iNum;
|
||
}
|
||
|
||
//获取对应iNum结构体信息
|
||
char * GetStruct(int iNum)
|
||
{
|
||
int iStationid = 0 ;
|
||
if( bEmbed ) iStationid = 0 ;
|
||
StructStation * pStation1 ;
|
||
pStation1 = pStation + iStationid;
|
||
|
||
return pStation1->chStruct[iNum];
|
||
}
|
||
|
||
//获取结构体信息条数
|
||
int GetStructNum()
|
||
{
|
||
int iStationid = 0 ;
|
||
if( bEmbed ) iStationid = 0 ;
|
||
StructStation * pStation1 ;
|
||
pStation1 = pStation + iStationid;
|
||
|
||
return pStation1->StructNum;
|
||
}
|
||
|
||
//获取对应iNum上传结构体信息
|
||
char *GetStructUp(int iNum)
|
||
{
|
||
int iStationid = 0 ;
|
||
if( bEmbed ) iStationid = 0 ;
|
||
StructStation * pStation1 ;
|
||
pStation1 = pStation + iStationid;
|
||
|
||
return pStation1->chStructUp[iNum];
|
||
}
|
||
|
||
//获取上传结构体信息条数
|
||
int GetStructUpNum()
|
||
{
|
||
int iStationid = 0 ;
|
||
if( bEmbed ) iStationid = 0 ;
|
||
StructStation * pStation1 ;
|
||
pStation1 = pStation + iStationid;
|
||
|
||
return pStation1->StructUpNum;
|
||
}
|
||
|
||
//获取对应iNum下传结构体信息
|
||
char *GetStructDown(int iNum)
|
||
{
|
||
int iStationid = 0 ;
|
||
if( bEmbed ) iStationid = 0 ;
|
||
StructStation * pStation1 ;
|
||
pStation1 = pStation + iStationid;
|
||
|
||
return pStation1->chStructDown[iNum];
|
||
}
|
||
|
||
//获取下传结构体信息条数
|
||
int GetStructDownNum()
|
||
{
|
||
int iStationid = 0 ;
|
||
if( bEmbed ) iStationid = 0 ;
|
||
StructStation * pStation1 ;
|
||
pStation1 = pStation + iStationid;
|
||
|
||
return pStation1->StructDownNum;
|
||
}
|
||
|
||
int GetStructDownProgId()
|
||
{
|
||
int iStationid = 0 ;
|
||
if( bEmbed ) iStationid = 0 ;
|
||
StructStation * pStation1 ;
|
||
pStation1 = pStation + iStationid;
|
||
|
||
return pStation1->StructDownProg;
|
||
}
|
||
|
||
//获取系统变量的值
|
||
double GetSysItem(int id)
|
||
{
|
||
return *( pSysItem + id ) ;
|
||
}
|
||
|
||
//设置系统变量的值
|
||
void SetSysItem( int id , double dValue)
|
||
{
|
||
*( pSysItem + id ) = dValue ;
|
||
} |