📄 new_communication.c
字号:
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;
}
else if(buf[0]==0x44)/*接收到数据包*/
{
if(buf[1]==AskDevData[1])
{
if(NetNode[netwk][node].flag==1)/*找到已存在节点*/
{
NetNode[netwk][node].timeout=5;//重新设定节点丢失的时间溢出为5
/*将zigbee节点号于实际子节点号相对应*/
NetwkCode = (unsigned char)netwk;
NodeCode = (buf[3]>>4)&0x0f;
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -