?? communication.c
字號:
add_len = (int)*mail_add_len;
name=IICReadInt(IIC_DEV_0,0x0023,name_len);
address=IICReadInt(IIC_DEV_0,0x0043,add_len);
for(i=0,j=0;j<name_len,i<add_len;j++,i++)
{
NameStr[j] = *name;//用戶名
AddressStr[i] = *address;//用戶地址
name++,address++;
}
NameStr[name_len] = '\0';
AddressStr[add_len] = '\0';
}
/*********************************************************************
*函數名：Get_Collect_Time 獲取數據采集設定時間
*功能：通過I2C從24c64中讀取數據采集設定時間參數
**********************************************************************/
void Get_Collect_Time(void)
{
int i;
BYTE *ds_inf_hour_sta;
BYTE *ds_inf_hour_end;
BYTE *ds_inf_min_sta;
BYTE *ds_inf_min_end;
BYTE *ds_sel_inf;
/*讀取用戶選擇以何種形式采集數據的信息*/
/*我們定義了三種數據采集形式*/
ds_sel_inf = IICReadInt(IIC_DEV_0,0x00c0,2);
for(i=0;i<2;i++)
{
DsSelectTime[i] = *ds_sel_inf;
ds_sel_inf++;
}
DsSelectTime[2] = '\0';
/*讀取采集時間設定的開始時間和結束時間*/
ds_inf_hour_sta = IICReadInt(IIC_DEV_0,0x00c3,2);
DsHourStaStr = Bcd2char(ds_inf_hour_sta);
ds_inf_hour_end = IICReadInt(IIC_DEV_0,0x00c9,2);
DsHourEndStr = Bcd2char(ds_inf_hour_end);
ds_inf_min_sta = IICReadInt(IIC_DEV_0,0x00c6,2);
DsMinStaStr = Bcd2char(ds_inf_min_sta);
ds_inf_min_end = IICReadInt(IIC_DEV_0,0x00cc,2);
DsMinEndStr = Bcd2char(ds_inf_min_end);
}
/*********************************************************************
*函數名：Anniu_Inf_Send 按鈕報警信息發送
*功能：緊急按鈕報警信息發送程序
**********************************************************************/
void Anniu_Inf_Send(void)
{
BYTE tittle[50];
BYTE body[50];
WORD y1,y2;
BYTE TimeBuffer[8];
BYTE SendMailData[20];
memset(SendMailData,'\0',sizeof(SendMailData));
/*將時間按規定格式打包*/
y1=date_encoder(&TimeBuffer[0]);
SendMailData[0]=(unsigned char)(y1>>8);
SendMailData[1]=(unsigned char)(y1&0x00ff);
y2=time_encoder(&TimeBuffer[0]);
SendMailData[2]=(unsigned char)(y2>>8);
SendMailData[3]=(unsigned char)(y2&0x00ff);
SendMailData[4] = Bit_Xor(4,SendMailData);
sprintf(tittle,"jing ji an niu bao ji");
sprintf(body,"jing ji an niu bei ji dong");
mail(DstStr,SrcStr,tittle,body,SendMailData);
anniu_flag=1;
Get_Time(&TimeBuffer[0]);
TimeSize=sprintf(AnniuTimeBuffer,"(時間%02i/%02i/%02i;%02i:%02i:%02i)", \
ds_1302_time.year,ds_1302_time.month,ds_1302_time.date,ds_1302_time.hour, \
ds_1302_time.min,ds_1302_time.sec);
Renew_Html();
}
/*********************************************************************
*函數名：Judge_Node_Type 判斷節點類型
*功能：判斷節點類型并顯示
**********************************************************************/
void Judge_Node_Type(int i,int j,BYTE NodeFuntionCoding)
{
switch(NodeFuntionCoding)
{
case 0x01: NetNode[i][j].funtion="數據采集節點";break;
case 0x02: NetNode[i][j].funtion="數據采集節點";break;
case 0x03: NetNode[i][j].funtion="控制節點";break;
case 0x04: NetNode[i][j].funtion="報警節點";break;
case 0x05: NetNode[i][j].funtion="報警節點";break;
case 0x06: NetNode[i][j].funtion="兩路數據采集節點";break;
case 0x07: NetNode[i][j].funtion="PI1+AI";break;
case 0x09: NetNode[i][j].funtion="PI1+DI2";break;
case 0x0a: NetNode[i][j].funtion="PI1+DI1";break;
case 0x0f: NetNode[i][j].funtion="設防節點";break;
default:NetNode[i][j].funtion="0";
}
}
/*********************************************************************
*函數名：Select_Time_Interval 采集數據時間判斷函數
*功能：根據用戶選擇的采集時間來判斷是否到達采集時間時刻
**********************************************************************/
WORD Select_Time_Interval(void)
{
BYTE TimeBuffer[8];
BYTE tmp1,tmp2;
BYTE TmpIntervalTime1 = 01;
BYTE TmpIntervalTime2 = 03;
if(strcmp(DsSelectTime,"11") == 0)/*設置為給定時間讀取數據*/
{
Get_Time(&TimeBuffer[0]);/*獲取時間*/
/*判斷是否在設定時間范圍之內*/
if((ds_1302_time.hour>DsHourStaStr)||((ds_1302_time.hour==DsHourStaStr) \
&&(ds_1302_time.min>DsMinStaStr)))
{
if((ds_1302_time.hour<DsHourEndStr)||((ds_1302_time.hour==DsHourEndStr) \
&&(ds_1302_time.min<DsMinEndStr)))
{
if(ds_inf_flag == 1)/*標志ds_inf_flag為進入設定時間段標志*/
{
printf("進入定時讀數據\n");
return(0);}
else
{printf("已讀過數據\n");return(100);}
}
else
{
printf("跳出時間間隔\n");
ds_inf_flag = 1;
return(100);
}
}
ds_inf_flag = 1;
return(100);
}
else if(strcmp(DsSelectTime,"22") == 0)/*設置為每24小時讀取數據一次*/
{
Get_Time(&TimeBuffer[0]);/*獲取時間*/
if(ds_1302_time.hour > IntervalTime)
{
if(strcmp(ds_1302_time.hour,"23") == 0)
{
IntervalTime = 0;
return(0);
}
else{
IntervalTime = ds_1302_time.hour;
return(0);}
}
else
{return(100);}
}
else if(strcmp(DsSelectTime,"33") == 0)/*設置為每1小時讀取數據一次*/
{
Get_Time(&TimeBuffer[0]);/*獲取時間*/
tmp1 = ds_1302_time.min-IntervalTime;
tmp2 = (ds_1302_time.min+60)-IntervalTime;
if((tmp1 > TmpIntervalTime1)||((tmp2 > TmpIntervalTime1) \
&&(tmp2 < TmpIntervalTime2)))
{
IntervalTime = ds_1302_time.min;
return(0);
}
else {return(100);}
}
else {printf("未設定時間讀取數據\n");return(100);}
}
/*********************************************************************
*函數名：main 主函數
*功能：初始化進程，實現串口通訊、數據采集、動態網頁的更新功能
**********************************************************************/
int main()
{
int pipe_fd,inf_pipe_fd,reply_pipe_fd,anniu_pipe_fd,init_pipe_fd;
int write_flag = 0;
int inf_num = 0;
int Data_Flag;
int testdev;
int fd,res,re,i,m,j,netwk,node,netwk1,node1;
int open_mode=O_RDONLY|O_NONBLOCK;
WORD restr;
BYTE PipeBuffer[BUFFER_SIZE];
BYTE PipeBuffer1[256];
struct termios oldtio,newtio;
BYTE NetwkCode,NodeCode;
BYTE tittle[30];
BYTE body[50];
BYTE *DataStr,tmp_buf[20];
BYTE buf[20];
BYTE AskDevData[6]={0x44,0x00,0x02,0x00,0x80,0xc6};//應答幀格式
BYTE AskData[6]={0x44,0x00,0x02,0x00,0x82,0xc4}; //應答幀格式
BYTE ResDevData[7]={0x44,0x00,0x03,0x00,0x98,0x00,0x00};
BYTE *SendMailStr;
WORD egy;
float cell1;
int alarm_return;
Get_User_Inf(); /*初始化用戶信息*/
Get_Collect_Time();/*初始化數據采集時間*/
Get_Mail_Address();/*初始化郵箱地址*/
DataStr = tmp_buf;
/*網絡中每個子節點包含節點信息的結構體賦初值*/
for(i=0;i<NetNum;i++)
{
for(j=0;j<NodeNum;j++)
{
NetNode[i][j].flag=0;
NetNode[i][j].timeout=5;/*設定節點丟失的時間溢出范圍*/
NetNode[i][j].data_flag=0;
NetNode[i][j].data_timeout=5;/*數據采集功能失效時間范圍*/
NetNode[i][j].state="正常";
}
}
/* 在使裝置非同步化前, 安裝訊號處理程序 */
saio.sa_handler = Signal_Handler_IO;
saio.sa_mask = 0;
saio.sa_flags = 0;
saio.sa_restorer = NULL;
sigaction(SIGIO,&saio,NULL);
/* 開啟數據機裝置以讀取并寫入而不以控制 tty 的模式 *
* 因為不想程序在送出 CTRL-C 後就被殺掉. */
fd = open(MODEMDEVICE, O_RDWR | O_NOCTTY );
if (fd <0) {perror(MODEMDEVICE); exit(-1); }
fcntl(fd, F_SETOWN, getpid());
fcntl(fd, F_SETFL, FASYNC);
tcgetattr(fd,&oldtio); /* 儲存目前的序列埠設定 */
bzero(&newtio, sizeof(newtio)); /* 清除結構體以放入新的序列埠設定值 */
newtio.c_cflag = BAUDRATE | CRTSCTS | CS8 | CLOCAL | CREAD;
/* IGNPAR : 忽略經同位元檢查後, 錯誤的位元組
ICRNL : 比 CR 對應成 NL (否則當輸入訊號有 CR 時不會終止輸入)
在不然把裝置設定成 raw 模式(沒有其它的輸入處理) */
newtio.c_iflag = IGNPAR;
/* Raw 模式輸出. */
newtio.c_oflag = 0;
/* ICANON : 致能標準輸入, 使所有回應機能停用, 并不送出信號以叫用程式 */
newtio.c_lflag = 0;
newtio.c_cc[VTIME] = 5; /* 不使用分割字元組的計時器5*0.1s */
newtio.c_cc[VMIN] = 3; /* 在讀取到 3 個字元前先停止 */
/* 現在清除數據機線并啟動序列埠的設定 */
tcflush(fd, TCIFLUSH);
tcsetattr(fd,TCSANOW,&newtio);
/*創建命令發送pipe管道*/
restr = mkfifo(FIFO_NAME,0777);
pipe_fd=open(FIFO_NAME,open_mode);
if(pipe_fd==-1){
perror(FIFO_NAME);exit(-1);
}
/*創建小區信息pipe管道*/
restr = mkfifo(INF_NAME,0777);
inf_pipe_fd=open(INF_NAME,open_mode);
if(inf_pipe_fd==-1){
perror(INF_NAME);exit(-1);
}
/*創建應答小區信息pipe管道*/
restr = mkfifo(REPLY_NAME,0777);
reply_pipe_fd=open(REPLY_NAME,open_mode);
if(reply_pipe_fd==-1){
perror(REPLY_NAME);exit(-1);
}
/*創建緊急按鈕發送信息pipe管道*/
restr = mkfifo(ANNIU_NAME,0777);
anniu_pipe_fd=open(ANNIU_NAME,open_mode);
if(anniu_pipe_fd==-1){
perror(ANNIU_NAME);exit(-1);
}
/*創建信息初始化pipe管道*/
restr = mkfifo(INIT_NAME,0777);
init_pipe_fd=open(INIT_NAME,open_mode);
if(init_pipe_fd==-1){
perror(INIT_NAME);exit(-1);
}
/*查詢子網中的節點是否存在，并請求其電池電量*/
for(netwk=0;netwk<NetNum+1;netwk++)
{
/*子網1中有節點0，而子網0中沒有節點0，有一一對應表*/
/*子網0中節點0是主節點*/
if(netwk == 0) {node = 1;}
else if(netwk == NetNum) //復位從新開始
{netwk = 0; node = 1;AskDevData[1]= inquire_encode1;}//AskDevData[1]重新置0
else
{node = 0;}
for(;node<NodeNum;node++)
{
AskDevData[1]++;/*按Zigbee節點號進行查詢，自加一*/
AskDevData[3] = inquire_encode3;
AskDevData[5] = Bit_Xor(5,AskDevData);
/*以下為查詢節點存在否，要求發送電池電量幀*/
for(i=0;i<23;i++) /*設定查詢時間間隔*/
{
if(write_flag==0)
{
memset(PipeBuffer,'\0',sizeof(PipeBuffer));
write(fd,AskDevData,strlen(AskDevData)); //查詢節點幀發送
/*查詢緊急按鈕報警*/
res=read(anniu_pipe_fd,PipeBuffer,20); /*若檢測到報警則無需掛起等待*/
if(res!=0)
{
Anniu_Inf_Send();
goto nexttag;
}
}
else {write_flag=0;}
usleep(1000000);
nexttag: if (wait_flag==FALSE)
{
memset(buf,'\0',sizeof(buf));
res = read(fd,buf,20);
buf[res]=0; /*zero terminate so printf works*/
if(res==1)
{
wait_flag = TRUE;
}
else if(buf[0]==0x43)/*zigbee返回正確應答*/
{
wait_flag = TRUE;
write_flag = 1;
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -