?? rxd.c
字號:
#include "ModBus.h"
/******************************************************************/
StrRxd xdata sys_rxd; //定義接收處理結構體
/******************************************************************/
/*******公有函數***************************************************/
void init_proc_rxd(void); //初始化串口通信變量
void process_rxd(void); //通信處理函數
void init_serial(void); //初始化串口
/*******私有函數***************************************************/
uint8 read_sys_rxd(void); //讀接收緩沖區
uint8 data_check(void); //校驗和檢驗
uint8 lenghchk(void); //數據長度檢驗
void data_change(void); //數據ASCII轉換成HEX
/******************************************************************/
void init_proc_rxd(void)
{
uint8 idata i;
for( i = 0;i < POOLLEN;i++ )
{
sys_rxd.pool[i] = 0;
sys_rxd.rec_buf[i] = 0;
sys_txd.pool[i] = 0;
sys_txd.combuf[i] = 0;
}
for( i = 0;i < 16;i++ )
{
sys_rxd.add_buf[i] = 0;
}
sys_rxd.front = 0;
sys_rxd.rear = 0;
sys_rxd.frm_num = 0;
sys_rxd.rd_byte = 0;
sys_rxd.start_0x7e = 0;
sys_rxd.end_0x0d = 0;
sys_txd.txd_len = 0;
}
/*****************************************************************/
uint8 read_sys_rxd(void)
{
if( sys_rxd.rear == sys_rxd.front )
{
return WRONG;
}
else
{
sys_rxd.rd_byte = sys_rxd.pool[sys_rxd.front];
sys_rxd.front = (sys_rxd.front+1) % POOLLEN;
return RIGHT;
}
}
/*****************************************************************/
uint8 data_check(void)
{
uint8 add_len,temp;
uint8 i,j,k,fram_temp;
uint16 chk_sum,chk_sum_temp;
fram_temp = sys_rxd.frm_num;//如何防止在處理數據的同時新的中斷使該值變化
add_len = 0;
if( fram_temp )//接收的一幀完整數據
{
fram_temp -= 1;
j = sys_rxd.add_buf[fram_temp * 2];
k = sys_rxd.add_buf[fram_temp * 2 + 1];
if(k > j)
{
add_len = k-j;
}
else
{
add_len = (POOLLEN - j ) + k;//地址確認
}
sys_rxd.front = j;
chk_sum = 0;
for( i = 0;i < add_len - 4;i++ ) //4 byte is chuck sum
{
read_sys_rxd(); //the poionter is add1
if( sys_rxd.rd_byte == FRAME_START )
{
sys_rxd.rd_byte = 0;
}
chk_sum += sys_rxd.rd_byte;
}
chk_sum = (~chk_sum) + 1;
chk_sum_temp = 0;
for(i=0;i<4;i++)
{
read_sys_rxd();
temp = sys_rxd.rd_byte;
if(temp > 0x40)
{
temp -= 0x37; // get the hex valume
}
else
{
temp -= 0x30;
}
chk_sum_temp += temp;
if( i < 3 )
{
chk_sum_temp = chk_sum_temp << 4;
}
}
if( chk_sum_temp == chk_sum )
{
return RIGHT;
}
else
{
return WRONG;
}
}
else
{
return WRONG;
}
}
/*****************************************************************/
uint8 lenghchk(void) //數據長度檢驗
{
uint8 link_sum,link_sum_temp;
uint8 add_len;
uint8 j,k,fram_temp;
if( sys_rxd.rec_buf[4] != lchksum(sys_rxd.rec_buf[5]) )
{
return WRONG;
}
fram_temp = sys_rxd.frm_num; //如何防止在處理數據的同時新的中斷使該值變化
if ( fram_temp == 0 )
{
return WRONG;
}
fram_temp--;
j = sys_rxd.add_buf[fram_temp*2];
k = sys_rxd.add_buf[fram_temp*2+1];
if(k>j)
{
add_len = k-j;
}
else
{
add_len = ( POOLLEN - j ) + k;
}
link_sum_temp = (add_len - 17);
link_sum = sys_rxd.rec_buf[5];
if(link_sum != link_sum_temp)
{
return WRONG;
}
else
{
return RIGHT;
}
}
/*****************************************************************/
void data_change(void)
{
uint8 add_len;
uint8 i,j,k,temp1,fram_temp;
uint8 temp;
fram_temp = sys_rxd.frm_num; //如何防止在處理數據的同時新的中斷使該值變化
if ( fram_temp == 0 )
{
return;
}
fram_temp--;
j = sys_rxd.add_buf[fram_temp*2];
k = sys_rxd.add_buf[fram_temp*2+1];
if(k>j)
{
add_len = k-j;
}
else
{
add_len = ( POOLLEN - j ) + k;
}
add_len = add_len / 2 + 1; //cup down 2 byte chksum
sys_rxd.front = j;
for(i = 0;i < add_len;i++ )
{
read_sys_rxd(); //the poionter is add1
if (sys_rxd.rd_byte == 0x0d)
{
sys_rxd.rec_buf[i] = 0xaa;
sys_rxd.rec_buf[i+1]=0x55;
return;
}
if (sys_rxd.rd_byte == 0x7e)
{
read_sys_rxd();
}
temp = sys_rxd.rd_byte;
if(temp>0x40)
{
temp-=0x37;
}
else
{
temp -=0x30;
}
temp = temp<<4;//高4位
read_sys_rxd();//the poionter is add1
temp1 = sys_rxd.rd_byte;
if(temp1>0x40)
{
temp1-=0x37;
}
else
{
temp1-=0x30;
}
sys_rxd.rec_buf[i] = temp+temp1; // include ver/adr/cid1/cid2/length/info
}
}
/*****************************************************************/
void process_rxd(void) //接收緩沖區中的數據 入處理緩沖區
{
while(sys_rxd.frm_num)
{
if(data_check() == WRONG)
{
sys_rxd.add_buf[sys_rxd.frm_num*2] = 0;
sys_rxd.add_buf[sys_rxd.frm_num*2+1] =0;
sys_rxd.frm_num --;
txd_uni(0x02); //校驗和錯誤
return;
}
data_change();
if( (sys_rxd.rec_buf[1] == ADDR ) ) //地址正確
{
if( lenghchk() ==WRONG ) //長度校驗
{
sys_rxd.add_buf[sys_rxd.frm_num*2] = 0;
sys_rxd.add_buf[sys_rxd.frm_num*2+1] =0;
sys_rxd.frm_num --;
txd_uni(0x03); //長度校驗錯誤
return;
}
if(sys_rxd.rec_buf[0] != VER)
{
sys_rxd.add_buf[sys_rxd.frm_num*2] = 0;
sys_rxd.add_buf[sys_rxd.frm_num*2+1] =0;
sys_rxd.frm_num --;
txd_uni(0x01); //版本錯
return;
}
if( (sys_rxd.rec_buf[2] != M_CID)) //設備ID錯
{
sys_rxd.add_buf[sys_rxd.frm_num*2] = 0;
sys_rxd.add_buf[sys_rxd.frm_num*2+1] =0;
sys_rxd.frm_num--;
txd_uni(0xe1); //設備ID錯
return;
}
switch(sys_rxd.rec_buf[3])
{
case 0x44:
txd_sta();
break;
case 0x4f:
txd_uni(0x4f); //發送通訊協議版本號
break;
case 0x50:
txd_uni(0x50); //發送設備地址
break;
case 0x51:
txd_man(); //發送設備廠家信息
break;
case 0x60:
txd_uni(0x60); //系統初始化
break;
default:
txd_uni(0x04); //無效命令
break;
}
}
sys_rxd.frm_num--;
}
}
/*****************************************************************/
void init_serial(void)
{
//串行口波特率等設置
TMOD=0x21; // T1 mode 2 T0,mode 1 //GATE C/T M1 M0 GATE C/T M1 M0
TL1=0xfa; // 0xfa=4800 bps 0xfd=9600 bps 0xe8 = 1200 0xf4 = 2400
TH1=0xfa;
TH0=-(10000/256);
TL0=-(10000%256);
PCON=0; //波特率不變等設置
SCON=0x50; //串口1方式1，允許接收
IT0=1; //外部中斷0下降沿有效
IT1=1; //外部中斷1下降沿有效
TR0=1; //啟動定時器0
TR1=1; //啟動定時器1
ET0=1; //開放定時器0中斷
ES=1; //串行中斷
EX0=0; //外部中斷0
EX1=1; //外部中斷1
EA=1; //開總中斷
// RS485EN = 0;
}
/*****************************************************************/
void serial_uart(void) interrupt 4
{
uchar idata temp;
uchar idata num;
if(RI)
{
RI = 0;
temp = SBUF;
if( sys_rxd.start_0x7e && (temp != FRAME_END) )
{
sys_rxd.pool[sys_rxd.rear] = temp;
sys_rxd.rear = (sys_rxd.rear + 1) % POOLLEN;
return;
}
else
{
if( (temp ^ FRAME_START)==0 ) //如果接收到包起始位
{
if( (sys_rxd.start_0x7e) && (sys_rxd.end_0x0d) )
{
sys_rxd.rear = sys_rxd.add_buf[num];
}
else
{ //第一次接收到起始位
sys_rxd.start_0x7e = 1;
sys_rxd.end_0x0d = 1;
num = sys_rxd.frm_num * 2; //新的一幀的起始地址下標
sys_rxd.add_buf[num] = sys_rxd.rear; //起始地址保存
}
sys_rxd.pool[sys_rxd.rear] = temp;
sys_rxd.rear=(sys_rxd.rear+1) % POOLLEN;
return;
}
else
{
if( sys_rxd.start_0x7e && ( temp == FRAME_END ) )
{
sys_rxd.end_0x0d = 0;
sys_rxd.start_0x7e = 0;
sys_rxd.pool[sys_rxd.rear] = temp;
sys_rxd.rear = (sys_rxd.rear+1) % POOLLEN;
num = sys_rxd.frm_num*2+1;//結束地址位
if(sys_rxd.rear==0) //對于POOLLEN不是255的時候，如果直接-1做尾地址。肯定造成尾地址錯誤。因為 0-1＝255
{
sys_rxd.add_buf[num] = POOLLEN - 1;//在寫進后的地址已加上1
}
else
{
sys_rxd.add_buf[num] = sys_rxd.rear-1;//在寫進后的地址已加上1
}
sys_rxd.frm_num++;//增加一幀//成功才加一位
sys_rxd.frm_num = sys_rxd.frm_num % 16;
return;
}
}
}
}
}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -