TMRWatchNew/tmr/buffer.c

#include "ring_buffer.h"
#include <rtthread.h>
#include "usart.h"
#include "weight.h"
#include "flash.h"
#include "plan.h"
#include "display.h"
#include "button.h"
#include "xBeeAppEscapingMode.h"

rt_sem_t thread_EmptyBuffer_sem = RT_NULL;

rt_sem_t uart1_lock = RT_NULL;
rt_sem_t uart2_lock = RT_NULL;
rt_sem_t uart3_lock = RT_NULL;
rt_sem_t uart4_lock = RT_NULL;
rt_sem_t uart5_lock = RT_NULL;


#define BUF_SIZE 256
ring_buffer usart1_buf,usart2_buf,usart3_buf,uart4_buf,uart5_buf;
ring_buffer *rb_usart1,*rb_usart2,*rb_usart3,*rb_uart4,*rb_uart5;
unsigned char rb_buffer1[BUF_SIZE],rb_buffer2[BUF_SIZE*4],rb_buffer3[BUF_SIZE],rb_buffer4[BUF_SIZE],rb_buffer5[BUF_SIZE];

ring_buffer display_buf;
ring_buffer *rb_display;
unsigned char rb_display_buffer[BUF_SIZE];

ring_buffer _SendWeightQueue,_XbeeQueue,_XbeeAPIQueue,_RemoteQueue;
ring_buffer *SendWeightQueue,*XbeeQueue,*XbeeAPIQueue,*RemoteQueue;
unsigned char SendWeightQueue_bf[BUF_SIZE*4],XbeeQueue_bf[BUF_SIZE*2],XbeeAPIQueue_bf[BUF_SIZE*4],RemoteQueue_bf[BUF_SIZE*2];

ring_buffer _RecWeightQueue;
ring_buffer *RecWeightQueue;
uint8_t RecWeightQueue_bf[128];

uint8_t usart1_send_data[64];
uint8_t usart2_send_data[256];
uint8_t usart3_send_data[64];
uint8_t uart4_send_data[256];

uint8_t flag_uart1_send = 0;
uint8_t flag_uart2_send = 0;
uint8_t flag_uart3_send = 0;
uint8_t flag_uart4_send = 0;

unsigned char XbeeConst_CenterAddress[8] = {0x00,0x00,0x00,0x00,0x00,0x00,0xFF,0xFF};  //开始地址 0xFF
unsigned char XbeeConst_CCAddress[8] = {0x00,0x00,0x00,0x00,0x00,0x00,0xFF,0xFF};      //开始地址 0xFF                                 //开始地址 0x10
unsigned char XbeeConst_RemoteAddress = 0x01; // 远程TMR地址

static unsigned char XbeeConst_FRxBufAPI[100];        //处理无线临时表 
unsigned char XbeeConst_ReadAPINum = 0;
static unsigned char XbeeConst_needEscape=0;
unsigned char XbeeConst_FRemoteTxBuf[]= {0x00,0x7E,0x15,0x00,0xF1,0x7E,0x45,
                                                0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,
                                                0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,
                                                0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,
                                                0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00
                                               };        //处理铲车临时表

static unsigned char XbeeConst_FRxBuf0[100];        //处理完整无线临时表
static unsigned char XbeeConst_FRxBuf0_Remote[100];        //处理完整铲车无线临时表


static unsigned char XbeeConst_FrameLength0 = 0;
static unsigned char XbeeConst_ReadNum0 = 0;

static unsigned char XbeeConst_FrameLength0_Remote = 0, XbeeConst_ReadNum0_Remote = 0;

unsigned char XbeeConst_FrameNumLast=0;  //上次发送的帧编号
unsigned char XbeeConst_FTxBuf0[50];        //处理发送无线临时表

unsigned char* XbeeConst_PTxBuf0;        //处理发送无线临时表
unsigned char* XbeeConst_PRemoteTxBuf0;        //处理发送远程显示临时表																					 
unsigned char ccsend = 0;
																							 
extern unsigned char  iscowweight;
		
unsigned char readyPop = 0;			
static unsigned char XbeeConst_FRxBuf12[100];        //处理完整无线临时表					


char b[40] = { '0','1','2','3','4','5','6','7','8','9','A','B','C','D','E','F','G','H','I','J','K','L','M','N','O','P','Q','R','S','T','U'};

unsigned char* BleApp2MakeFrame(unsigned short dist,unsigned char cmd,unsigned char type,unsigned char* buf)//返回一个处理完成后的数组的首地址
{
    unsigned char len = buf[0];
	  unsigned char BLEMakeFrame[100];//makeFrame保存转义完成后的数据
    unsigned char l;
    unsigned char xLen = 1;//处理后的数组长度,放在数组的第一位

    BLEMakeFrame[xLen++] = 0x41;
    BLEMakeFrame[xLen++] = 0x54;
    BLEMakeFrame[xLen++] = 0x2b;
    BLEMakeFrame[xLen++] = 0x4d;
    BLEMakeFrame[xLen++] = 0x45;
    BLEMakeFrame[xLen++] = 0x53;
    BLEMakeFrame[xLen++] = 0x48;
    BLEMakeFrame[xLen++] = cmd;
    BLEMakeFrame[xLen++] = (dist>>8)&0xFF;
    BLEMakeFrame[xLen++] = dist&0xFF;
	  if (type==0)
		{			
			BLEMakeFrame[xLen++] = type;	
			for(l = 4; l < 15; l++)	BLEMakeFrame[xLen++] = buf[l];
		}
		else{	
      BLEMakeFrame[xLen++] = type;			
			for(l = 4; l < 7; l++) BLEMakeFrame[xLen++] = buf[l];
			for(l = 15; l < 23; l++)	BLEMakeFrame[xLen++] = buf[l];
		}
    BLEMakeFrame[xLen++] = 0x0D;
    BLEMakeFrame[xLen++] = 0x0A;
    BLEMakeFrame[0] = xLen - 1;
    return BLEMakeFrame;//返回最终数组
}


void RB_init(void)
{
    rb_usart1 = &usart1_buf;
    rb_init(rb_usart1, sizeof(rb_buffer1)/sizeof(rb_buffer1[0]), rb_buffer1);

    rb_usart2 = &usart2_buf;
    rb_init(rb_usart2, sizeof(rb_buffer2)/sizeof(rb_buffer2[0]), rb_buffer2);

    rb_usart3 = &usart3_buf;
    rb_init(rb_usart3, sizeof(rb_buffer3)/sizeof(rb_buffer3[0]), rb_buffer3);

    rb_uart4 = &uart4_buf;
    rb_init(rb_uart4, sizeof(rb_buffer4)/sizeof(rb_buffer4[0]), rb_buffer4);

    rb_uart5 = &uart5_buf;
    rb_init(rb_uart5, sizeof(rb_buffer5)/sizeof(rb_buffer5[0]), rb_buffer5);

   // if (WeightConst_SBType==4||WeightConst_SBType==6) {
        rb_display = &display_buf;
        rb_init(rb_display, sizeof(rb_display_buffer)/sizeof(rb_display_buffer[0]), rb_display_buffer);
  //  }

    SendWeightQueue = &_SendWeightQueue;
    rb_init(SendWeightQueue, sizeof(SendWeightQueue_bf)/sizeof(SendWeightQueue_bf[0]), SendWeightQueue_bf);

    XbeeQueue = &_XbeeQueue;
    rb_init(XbeeQueue, sizeof(XbeeQueue_bf)/sizeof(XbeeQueue_bf[0]), XbeeQueue_bf);

    XbeeAPIQueue = &_XbeeAPIQueue;
    rb_init(XbeeAPIQueue, sizeof(XbeeAPIQueue_bf)/sizeof(XbeeAPIQueue_bf[0]), XbeeAPIQueue_bf);

		RecWeightQueue = &_RecWeightQueue;
    rb_init(RecWeightQueue, sizeof(RecWeightQueue_bf)/sizeof(RecWeightQueue_bf[0]), RecWeightQueue_bf);

    RemoteQueue = &_RemoteQueue;
    rb_init(RemoteQueue, sizeof(RemoteQueue_bf)/sizeof(RemoteQueue_bf[0]), RemoteQueue_bf);
}

void USART_Push(unsigned char address, unsigned char data)
{
    if (address==1)
    {
        rb_push_insert(rb_usart1, data);
    }
    else if (address==2)
    {
        rb_push_insert(rb_usart2, data);
    }
    else if (address==3)
    {
        rb_push_insert(rb_usart3, data);
    }
    else if (address==4)
    {
        rb_push_insert(rb_uart4, data);
    }
    else if (address==5)
    {
        rb_push_insert(rb_uart5, data);
    }
}

void RX_API(void) {
    unsigned char  tempval, checksum = 0;
    if (rb_full_count(XbeeAPIQueue)> 0) {
        tempval = rb_remove(XbeeAPIQueue);  //继续存数据
		//		rt_kprintf(" %02X",tempval);
        switch (XbeeConst_ReadAPINum) {
        case 0:
            if (tempval == 0x7e) { //协议头前面1个7E判断
                XbeeConst_FRxBufAPI[0] = tempval;
                XbeeConst_ReadAPINum = 1;
            }
            break;
        case 1:
            if (tempval == 0x7e) { //协议头前面1个7E判断
                XbeeConst_FRxBufAPI[0] = tempval;
                XbeeConst_ReadAPINum = 1;
            }
            else {
                if (tempval == 0x7D)	XbeeConst_needEscape = 1;
                else
                {
                    if (XbeeConst_needEscape) {
                        XbeeConst_needEscape=0;
                        tempval = tempval^0x20;
                    }
                    XbeeConst_FRxBufAPI[XbeeConst_ReadAPINum++] = tempval;
                }
            }
            break;
        case 2:
            if (tempval == 0x7e) { //协议头前面1个7E判断
                XbeeConst_FRxBufAPI[0] = tempval;
                XbeeConst_ReadAPINum = 1;
            }
            else {
                if (tempval == 0x7D)	XbeeConst_needEscape = 1;
                else
                {
                    if (XbeeConst_needEscape) {
                        XbeeConst_needEscape=0;
                        tempval = tempval^0x20;
                    }
                    XbeeConst_FRxBufAPI[XbeeConst_ReadAPINum++] = tempval;
                }
            }
            break;
        default:
            if (tempval == 0x7e) { //协议头前面1个7E判断
                XbeeConst_FRxBufAPI[0] = tempval;
                XbeeConst_ReadAPINum = 1;
            }
            else {
                if (tempval == 0x7D)	XbeeConst_needEscape = 1;
                else
                {
                    if (XbeeConst_needEscape) {
                        XbeeConst_needEscape=0;
                        tempval = tempval^0x20;
                    }
                    XbeeConst_FRxBufAPI[XbeeConst_ReadAPINum++] = tempval;
                }
            }

            if (XbeeConst_ReadAPINum > XbeeConst_FRxBufAPI[2]+3) {     //读完已知长度的数据
						//	  rt_kprintf("\n");
                for (unsigned short i = 3; i < XbeeConst_FRxBufAPI[2]+3; i++)
                    checksum += XbeeConst_FRxBufAPI[i];
                if (((0xff - checksum)&0xFF) == XbeeConst_FRxBufAPI[XbeeConst_FRxBufAPI[2]+3])  //校验成功
                {
                    if (XbeeConst_FRxBufAPI[3] == 0x90) {
                        if((XbeeConst_FRxBufAPI[18]&0xF0) == 0xA0 || (XbeeConst_FRxBufAPI[18]) == 0x14)       //铲车数据
                        {
                            if ((XbeeConst_FRxBufAPI[18] == 0xA1 && WeightConst_SBType == 2) ||
                                    (XbeeConst_FRxBufAPI[18] != 0xA1 ))
                                for (unsigned short i = 15; i < XbeeConst_FRxBufAPI[2]+3; i++)
                                    rb_push_insert(RemoteQueue, XbeeConst_FRxBufAPI[i]);  //赋值数据到数组
                        }
                        else if (XbeeConst_FRxBufAPI[18] == 0xB2 && XbeeConst_FRxBufAPI[19] == 0x03)        //收到设置铲车定向
                        {
                            for (unsigned short i = 0; i < 8; i++)	XbeeConst_CCAddress[i] = XbeeConst_FRxBufAPI[i+4];
                            ccsend = (XbeeConst_FRxBufAPI[17] == XbeeConst_DeviceAddress);
                        }
                        else if (XbeeConst_FRxBufAPI[17] == XbeeConst_DeviceAddress || XbeeConst_FRxBufAPI[17] == 0xFF)
                            for (unsigned short i = 15; i < XbeeConst_FRxBufAPI[2]+3; i++)
                                rb_push_insert(XbeeQueue, XbeeConst_FRxBufAPI[i]);  //赋值数据到数组
												
                        if(XbeeConst_FRxBufAPI[18]==0x18)
                            for (unsigned short i = 0; i < 8; i++)
                                XbeeConst_CenterAddress[i] = XbeeConst_FRxBufAPI[i+4];
                    }
                }
                XbeeConst_ReadAPINum = 0; //循环计数清零
            }
            break;
        }
    }
}

static unsigned char planreget_save,planreget = 0;
static uint8_t foundlastplan_ ; 
void RX(void) {
    unsigned char tempval, checksum = 0;

    if (rb_full_count(XbeeQueue)> 0) {

        tempval = rb_remove(XbeeQueue);  //继续存数据

        switch (XbeeConst_ReadNum0) {
        case 0:
            if (tempval == 0x7e) { //协议头前面1个7E判断
                XbeeConst_FRxBuf0[XbeeConst_ReadNum0] = tempval;
                XbeeConst_ReadNum0++;
            }
            break;
        case 1:
            XbeeConst_FRxBuf0[XbeeConst_ReadNum0] = tempval;           //这个字节为帧长度
            XbeeConst_ReadNum0++;
            XbeeConst_FrameLength0 = XbeeConst_FRxBuf0[1] + 1; //算出帧长度
            break;
        default:
            XbeeConst_FRxBuf0[XbeeConst_ReadNum0] = tempval;       //读数据

            if (XbeeConst_ReadNum0 >= XbeeConst_FrameLength0) {     //读完已知长度的数据
                for (unsigned short i = 0; i < XbeeConst_FrameLength0; i++)
                    checksum += XbeeConst_FRxBuf0[i];

                if ((0xff - checksum) == XbeeConst_FRxBuf0[XbeeConst_FrameLength0])  //校验成功
                {
									  rt_strncpy(dataframehead.Buffer, XbeeConst_FRxBuf0, 4);
                    if ((dataframehead.data.addr&0x1F) == XbeeConst_DeviceAddress || dataframehead.data.addr == 0xFF) { //收到本设备的数据，不是本设备的不处理
                        if (dataframehead.data.frameType == 0x10) {   //实时重量
                            if (XbeeConst_FRxBuf0[XbeeConst_FrameLength0-1] == XbeeConst_FrameNumLast) {
															  save_read_ts('w');	
                                XbeeConst_CanSend=0x01;//取消无线发送锁定	
                            }
                        }

                        else if (dataframehead.data.frameType == 0x11 ) { //1号键回复
                            if (XbeeConst_FRxBuf0[XbeeConst_FrameLength0-1] == XbeeConst_FrameNumLast) {	
															  save_read_ts('k');																									
                                XbeeConst_CanSend=0x01;//取消无线发送锁定				
                            }
                        }

                        else if (dataframehead.data.frameType == 0x12 || dataframehead.data.frameType == 0x15) { //2号键内容
//												   	rt_kprintf("%02X//////////////////////////%02X \n",dataframehead.data.frameType,XbeeConst_FRxBuf0[XbeeConst_FRxBuf0[1]-1]);				
                            if (dataframehead.data.frameType == 0x12)
                            {   
                               // if(isn==1) {
                               //   clearScreenAll_();
                               //   delay_ms(100);
                               // }
															if (getPlaning==1)
															{
																planreget_save = 0;
																
																readyPop = 1;
																for (int i=0;i<XbeeConst_FRxBuf0[1]+2;i++)
																	XbeeConst_FRxBuf12[i] = XbeeConst_FRxBuf0[i];  
															}
															 //setWeightConst_initProduct();
															
												       //	rt_sem_release(pop_product_sem);//需要弹出最新内容
                            }
                            else if (dataframehead.data.frameType == 0x15)
                            {				
//															  rt_kprintf("--XbeeConst_lastsort:%02X \n", XbeeConst_lastsort);				
//                                rt_kprintf("0x15 ------index:%02X \n",XbeeConst_FRxBuf0[XbeeConst_FRxBuf0[1]-1]);															
																if (XbeeConst_lastsort==0xFD && XbeeConst_lastsort < XbeeConst_FRxBuf0[XbeeConst_FRxBuf0[1]-1])
																	 reset_read_ts('p');
															  if (readyPop==1 && getPlaning==1)
																{
																	//	readyPop = 0;
																		getPlaning=0;			
																		planreget = XbeeConst_FRxBuf12[XbeeConst_FRxBuf12[1]-3]&0x01;
																		reset_read_ts('p');
																		ts_pushArrary(&ts_plandb, XbeeConst_FRxBuf12, XbeeConst_FRxBuf12[1]+2); 
																			
//																		rt_kprintf("\n");			
//																	rt_kprintf("\n");			
//																	rt_kprintf("\n");			
//																		rt_kprintf("0x12-----------------------------\n");				
//																		rt_kprintf("pop index:%02X \n",XbeeConst_FRxBuf0[XbeeConst_FRxBuf0[1]-1]);
																		rt_sem_release(pop_product_sem);//需要弹出最新内容																		
																}			
																if (planreget_save==0 && planreget==1){																  
																	 XbeeConst_FRxBuf0[XbeeConst_FRxBuf0[1]-2] = XbeeConst_FRxBuf0[XbeeConst_FRxBuf0[1]-2] | 0x01;
																}
																planreget_save =1; 
																
																foundlastplan_ = 0xF0;
																foundlastplan_ = findlastplan();
																if ((XbeeConst_lastsort != XbeeConst_FRxBuf0[XbeeConst_FRxBuf0[1]-1] 
																	    && foundlastplan_ != XbeeConst_FRxBuf0[XbeeConst_FRxBuf0[1]-1])
																      || XbeeConst_FRxBuf0[XbeeConst_FRxBuf0[1]-1]>0xFD)
																		ts_pushArrary(&ts_plandb, XbeeConst_FRxBuf0, XbeeConst_FRxBuf0[1]+2); 
																save_read_ts('k');																
																XbeeConst_CanSend=0x01;//取消无线发送锁定	
																
																if (XbeeConst_FRxBuf0[XbeeConst_FRxBuf0[1]-1]<0xFD && getPlaning==0) { //如果没有结束，则发送05协议																																		
																			XbeeConst_lastsort = XbeeConst_FRxBuf0[XbeeConst_FRxBuf0[1]-1];
																			XbeeConst_lastinorout = XbeeConst_FRxBuf0[XbeeConst_FRxBuf0[1]-3]>>7;
//															    		rt_kprintf("XbeeConst_lastsort get:%02X \n", XbeeConst_lastsort);				
																			sendkey2(0xF5); 											
																}																	
																else if (XbeeConst_lastsort==0xFD && readyPop==0 && XbeeConst_lastsort < XbeeConst_FRxBuf0[XbeeConst_FRxBuf0[1]-1])
																{
																		rt_sem_release(pop_product_sem);//如果直接收到15，如全天结束或空计划，需要弹出最新内容
																}
																if (readyPop==1) readyPop = 0;													
                            }
															
                        }
                        else if (dataframehead.data.frameType == 0x14) {      //无线按键处理
                            RemoteSendDisplay = 0;

                            if (isCC)
                                checksum =0x7E + 0x05 +  ((XbeeConst_FRxBuf0_Remote[2] & 0x0F) << 4 ) | XbeeConst_DeviceAddress
                                          + 0xA4 + XbeeConst_FRxBuf0[4] + XbeeConst_FRxBuf0[5];
                            else
                                checksum =0x7E + 0x05 + XbeeConst_DeviceAddress + 0xA4 + XbeeConst_FRxBuf0[4] + XbeeConst_FRxBuf0[5];
                            XbeeConst_FRemoteTxBuf[0] = 0x07;
                            XbeeConst_FRemoteTxBuf[1] = 0x7E;
                            XbeeConst_FRemoteTxBuf[2] = 0x05;
                            if (isCC)
                                XbeeConst_FRemoteTxBuf[3] = ((XbeeConst_FRxBuf0_Remote[2] & 0x0F) << 4 ) | XbeeConst_DeviceAddress;
                            else
                                XbeeConst_FRemoteTxBuf[3] = XbeeConst_DeviceAddress;
                            XbeeConst_FRemoteTxBuf[4] = 0xA4;
                            XbeeConst_FRemoteTxBuf[5] = XbeeConst_FRxBuf0[4];
                            XbeeConst_FRemoteTxBuf[6] = XbeeConst_FRxBuf0[5];
                            XbeeConst_FRemoteTxBuf[7] = 0xff - checksum;
                            if (XbeeConst_UseAPI>0) {
																rt_sem_take(uart2_lock, RT_WAITING_FOREVER);				
                                setSendFrame_t(0x01,0x01,0xC1);
                                XbeeConst_PTxBuf0 = xBeeApp2MakeFrame(&userSendFrame_t, XbeeConst_FRemoteTxBuf);		
                                for (int i = 1; i <= XbeeConst_PTxBuf0[0]; i++) //将缓冲区发出
                                    usart2_send_data[i - 1] = XbeeConst_PTxBuf0[i];
															  HAL_UART_Transmit_DMA(&huart2, usart2_send_data, XbeeConst_PTxBuf0[0]);
																rt_sem_release(uart2_lock);
                            }
                            else {
																rt_sem_take(uart2_lock, RT_WAITING_FOREVER);
                                for (int i = 1; i <= XbeeConst_FRemoteTxBuf[0]; i++) //将缓冲区发出
                                    usart2_send_data[i - 1] = XbeeConst_FRemoteTxBuf[i];
															  HAL_UART_Transmit_DMA(&huart2, usart2_send_data, XbeeConst_FRemoteTxBuf[0]);
																rt_sem_release(uart2_lock);
                            }

                            RemoteSendDisplay = 1;
                            if (XbeeConst_FRxBuf0[4]==0x01 && button_state.b1 ==0 && delayKeying == 0)
														{		
																if (WeightConst_DELAYON == 0 && delayKeying == 0)
																{			
																		rt_sem_release(delay_key_sem); 			//收到1号键
																		sendkey1(0xF3, ((XbeeConst_FRxBuf0_Remote[2] >> 4) & 0x0F) );																	
																		WeightConst_AutoSingleNSecondPoint=0; // 防止自动跳转，重置自动记录指针
																		WeightConst_oksum = 0;
 																	  WeightConst_joksum = 0;
																		WeightConst_allsum = 0;
																		button_state.b1=1;  //5秒内不可按键
																}	
														}
                            else if (XbeeConst_FRxBuf0[4]==0x02 && button_state.b2==0) //收到2号键
                              //  sendkey2(0xF4);
																if(WeightConst_DELAYON==0)
																{
																		if (tsdb_recordcount('k')==0)
																		{		
																				sendkey2(0xF4);
//																				WeightConst_AutoSingleNSecondPoint=0; // 防止自动跳转，重置自动记录指针
//																				WeightConst_oksum = 0;
//																				WeightConst_allsum = 0;
																				
																		}
																}
																button_state.b2=1;  //5秒内不可按键
                        }
												

                        else if (dataframehead.data.frameType == 0xA1) {      //铲车显示处理
                            for (unsigned short i=4; i < 22; i++) {  //显示重量
                                uart4_send_data[i - 4] = XbeeConst_FRxBuf0[i];

                                uart4_send_data[18]=0;
                                for (int i = 2; i <18; i++)   //校验和
                                    uart4_send_data[18]=uart4_send_data[18]+uart4_send_data[i];
																rt_sem_take(uart4_lock, RT_WAITING_FOREVER);
															  HAL_UART_Transmit_DMA(&huart4, uart4_send_data, 19);
																rt_sem_release(uart4_lock);
                            }
                        }

                        else if (dataframehead.data.frameType == 0xA4) {      //无线按键成功处理
                            beep();
                        }
                        else if (dataframehead.data.frameType == 0x16) {   //设置无线模式
                            XbeeConst_UseAPI = XbeeConst_FRxBuf0[4];
                            write_Flash("API", &XbeeConst_UseAPI, sizeof(XbeeConst_UseAPI));       
                            setAPI();
                            beep();
                        }
                        else if (dataframehead.data.frameType == 0x17) {   //设置屏幕类型
                            WeightConst_SBType = XbeeConst_FRxBuf0[4];                            
                            write_Flash("PM", &WeightConst_SBType, sizeof(WeightConst_SBType)); 
                            beep();
                        }
                        else if (dataframehead.data.frameType == 0x19) {   //设置地址
                            XbeeConst_DeviceAddress = XbeeConst_FRxBuf0[4];
                            write_Flash("CH", &XbeeConst_DeviceAddress, sizeof(XbeeConst_DeviceAddress)); 
                            beep();
                        }
                        else if (dataframehead.data.frameType == 0x1A) {   //设置提取类型
                            WeightConst_TQ = XbeeConst_FRxBuf0[4];
                            write_Flash("TQ", &WeightConst_TQ, sizeof(WeightConst_TQ)); 
                        //----------    USART_Configuration();
                            beep();
                        }
                        else if (dataframehead.data.frameType == 0x1B) {   //设置网络编号
                            beep();
                            XbeeConst_NetAddress = XbeeConst_FRxBuf0[4];
                            write_Flash("WL", &XbeeConst_NetAddress, sizeof(XbeeConst_NetAddress)); 
                            setNetAddress();
                            beep();
                        }
                        else if (dataframehead.data.frameType == 0x18) {   //设置时间																									
                            XbeeConst_CanSend=0x01;//取消无线发送锁定
													  TimeConst.Buffer[0] = XbeeConst_FRxBuf0[7];													
													  TimeConst.Buffer[1] = XbeeConst_FRxBuf0[6];													
													  TimeConst.Buffer[2] = XbeeConst_FRxBuf0[5];													
													  TimeConst.Buffer[3] = XbeeConst_FRxBuf0[4];		
                            save_read_ts('k');
													  rt_sem_take(setTIME_lock, RT_WAITING_FOREVER);
                            write_Flash("TimeConst", &TimeConst, sizeof(TimeConst));		
													  rt_sem_release(setTIME_lock);
                            CanButton = 0x01;
                            beep();
                        }
                    
										}
                }
                XbeeConst_ReadNum0 = 0; //循环计数清零
                XbeeConst_FrameLength0 = 0;
            } else {
                XbeeConst_ReadNum0++;  //小于帧长度
                if (XbeeConst_ReadNum0>90)
                {
                    XbeeConst_ReadNum0 = 0; //循环计数清零
                    XbeeConst_FrameLength0 = 0;
                }
            }
            break;
        }
    }
}

void RX_Remote(void) {
    unsigned char tempval, checksum = 0;
    if (rb_full_count(RemoteQueue) > 0) {
        tempval = rb_remove(RemoteQueue);  //继续存数据

        switch (XbeeConst_ReadNum0_Remote) {
        case 0:
            if (tempval == 0x7e) { //协议头前面1个7E判断
                XbeeConst_FRxBuf0_Remote[XbeeConst_ReadNum0_Remote] = tempval;
                XbeeConst_ReadNum0_Remote++;
            }
            break;
        case 1:
            XbeeConst_FRxBuf0_Remote[XbeeConst_ReadNum0_Remote] = tempval;           //这个字节为帧长度
            XbeeConst_ReadNum0_Remote++;
            XbeeConst_FrameLength0_Remote= XbeeConst_FRxBuf0_Remote[1] + 1; //算出帧长度
            break;
        default:
            XbeeConst_FRxBuf0_Remote[XbeeConst_ReadNum0_Remote] = tempval;       //读数据
            if (XbeeConst_ReadNum0_Remote >= XbeeConst_FrameLength0_Remote) {     //读完已知长度的数据
                for (unsigned short i = 0; i < XbeeConst_FrameLength0_Remote; i++)
                    checksum += XbeeConst_FRxBuf0_Remote[i];

                if ((0xff - checksum) == XbeeConst_FRxBuf0_Remote[XbeeConst_FrameLength0_Remote])  //校验成功
                {
                    if (
                        (((XbeeConst_FRxBuf0_Remote[2] & 0x1F) == XbeeConst_RemoteAddress && (WeightConst_SBType == 2 || WeightConst_SBType == 7))
                         ||
                         ((XbeeConst_FRxBuf0_Remote[2] & 0x1F) == XbeeConst_DeviceAddress && (WeightConst_SBType != 2 && WeightConst_SBType != 7)))
                        ||
                        (XbeeConst_RemoteAddress==0 && XbeeConst_FRxBuf0_Remote[2]==0x0A)) { //收到本设备的数据，不是本设备的不处理
                        if ((XbeeConst_FRxBuf0_Remote[3] == 0xA1 && (WeightConst_SBType == 2 || WeightConst_SBType == 7) )
                                ||  (XbeeConst_FRxBuf0_Remote[3] == 0xF1 && (WeightConst_SBType == 2 || WeightConst_SBType == 7) )
                           )
                        {   //铲车显示处理
                            if (XbeeConst_FRxBuf0_Remote[14]==0xC8 && XbeeConst_FRxBuf0_Remote[15]==0xB7) //确认开始
                            {
                                XbeeConst_FRxBuf0_Remote[21] = 0x20;
                                XbeeConst_FRxBuf0_Remote[20] = 0x20;
                                XbeeConst_FRxBuf0_Remote[19] = 0x20;
                                XbeeConst_FRxBuf0_Remote[18] = 0x20;
                                XbeeConst_FRxBuf0_Remote[17] = 0x20;
                                XbeeConst_FRxBuf0_Remote[16] = 0x20;
															  XbeeConst_FRxBuf0_Remote[15] = 0x20;
															  XbeeConst_FRxBuf0_Remote[14] = b[XbeeConst_RemoteAddress];
                            }
                            else
                            {
                                XbeeConst_FRxBuf0_Remote[17] = XbeeConst_FRxBuf0_Remote[16];
														  	XbeeConst_FRxBuf0_Remote[16] = XbeeConst_FRxBuf0_Remote[15];
															  XbeeConst_FRxBuf0_Remote[15] = XbeeConst_FRxBuf0_Remote[14];
																XbeeConst_FRxBuf0_Remote[14] = b[XbeeConst_RemoteAddress];				
                            }

                            for (unsigned short i=4; i < 22; i++)   //显示重量
                                uart4_send_data[i - 4] = XbeeConst_FRxBuf0_Remote[i];
                            uart4_send_data[18]=0;
                            for (int i = 2; i <18; i++)   //校验和
                                uart4_send_data[18]=uart4_send_data[18]+uart4_send_data[i];
//                            if (WeightConst_SBType == 7)
//                            {
//                                for (int SendDisplay_i = 0; SendDisplay_i < 8; SendDisplay_i++) {
//                                    WeightConst_feed[SendDisplay_i] = uart4_send_data[2+SendDisplay_i] ;
//                                    WeightConst_Weight_display[7-SendDisplay_i] = uart4_send_data[10+SendDisplay_i] ;
//                                    WeightConst_Weight_display[7] = 0x20;
//                                }
//                                get_msg(4,//Xstart
//                                        8,//Ystart
//                                        1,//size
//                                        0,//reset
//                                        0,//speed
//                                        8,//字符个数
//                                        3,//界面数
//                                        0,//id
//                                        0x5B,//Xend
//                                        0,
//                                        &WeightConst_feed[0]//字码
//                                       );
//                                delay_ms(200);
//                                get_msg(92,//Xstart
//                                        4,//Ystart
//                                        2,//size
//                                        0,//reset
//                                        0,//speed
//                                        8,//字符个数
//                                        3,//界面数
//                                        1,//id
//                                        0xBF,//Xend
//                                        1,
//                                        &WeightConst_Weight_display[0]//字码
//                                       );

//                            }
//                            else
                            {
															 rt_sem_take(uart4_lock, RT_WAITING_FOREVER);
                               HAL_UART_Transmit_DMA(&huart4, uart4_send_data, 19);
															 rt_thread_mdelay(50);
															 rt_sem_release(uart4_lock);
                            }
                        }
                        else if (XbeeConst_FRxBuf0_Remote[3] == 0xA4 && (WeightConst_SBType == 2 || WeightConst_SBType == 7) )
                        {   //铲车收到无线按键成功处理
                            beep();
                        }
                        else if (
                            (XbeeConst_FRxBuf0_Remote[3] == 0xA2 ||  XbeeConst_FRxBuf0_Remote[3] == 0x14)
                            && (WeightConst_SBType != 2 && WeightConst_SBType != 7) && XbeeConst_FRxBuf0_Remote[1] == 0x05
                            //      (XbeeConst_FRxBuf0_Remote[3] == 0xA2 && WeightConst_SBType != 2 && XbeeConst_UseAPI)
                            //  ||  (XbeeConst_FRxBuf0_Remote[3] == 0x14 && WeightConst_SBType != 2 && !XbeeConst_UseAPI)
                        ) {      //TMR收到无线按键处理
                            RemoteSendDisplay = 0;
                            XbeeConst_FRemoteTxBuf[0] = 7;
                            XbeeConst_FRemoteTxBuf[1] = 0x7E;
                            XbeeConst_FRemoteTxBuf[2] = 0x05;
                            if (isCC)
                                XbeeConst_FRemoteTxBuf[3] = ((XbeeConst_FRxBuf0_Remote[2] & 0x0F) << 5 ) | (XbeeConst_DeviceAddress&0x1F);
                            else
                                XbeeConst_FRemoteTxBuf[3] = XbeeConst_DeviceAddress;
                            XbeeConst_FRemoteTxBuf[4] = 0xA4;
                            XbeeConst_FRemoteTxBuf[5] = XbeeConst_FRxBuf0_Remote[4];
                            XbeeConst_FRemoteTxBuf[6] = XbeeConst_FRxBuf0_Remote[5];
                            XbeeConst_FRemoteTxBuf[XbeeConst_FRemoteTxBuf[0]] = 0;
                            for (int i = 1; i < XbeeConst_FRemoteTxBuf[0]; i++)
                                XbeeConst_FRemoteTxBuf[XbeeConst_FRemoteTxBuf[0]] =
                                    XbeeConst_FRemoteTxBuf[XbeeConst_FRemoteTxBuf[0]]+XbeeConst_FRemoteTxBuf[i];

                            XbeeConst_FRemoteTxBuf[XbeeConst_FRemoteTxBuf[0]] = 0xFF - XbeeConst_FRemoteTxBuf[XbeeConst_FRemoteTxBuf[0]];

                            if (XbeeConst_UseAPI>0) {
																rt_sem_take(uart2_lock, RT_WAITING_FOREVER);			
                                setSendFrame_t(0x01,0x01,0xC1);
                                XbeeConst_PTxBuf0 = xBeeApp2MakeFrame(&userSendFrame_t, XbeeConst_FRemoteTxBuf);			
                                for (int i = 1; i <= XbeeConst_PTxBuf0[0]; i++) //将缓冲区发出
                                    usart2_send_data[i - 1] = XbeeConst_PTxBuf0[i];
															  HAL_UART_Transmit_DMA(&huart2, usart2_send_data, XbeeConst_PTxBuf0[0]);
																rt_thread_mdelay(50);
																rt_sem_release(uart2_lock);
                            }
                            else
                            {
															if (iscowweight<1 )
															{
																rt_sem_take(uart3_lock, RT_WAITING_FOREVER);
                                for (int i = 1; i <= XbeeConst_FRemoteTxBuf[0]; i++) //将缓冲区发出
                                    usart3_send_data[i - 1] = XbeeConst_FRemoteTxBuf[i];
															  HAL_UART_Transmit_DMA(&huart3, usart3_send_data, XbeeConst_FRemoteTxBuf[0]);
																rt_thread_mdelay(50);
																rt_sem_release(uart3_lock);
															}
                            }

                            RemoteSendDisplay = 1;
                            if (XbeeConst_FRxBuf0_Remote[4]==0x01 && button_state.b1==0)//收到1号键
                            {
                                if (pf_comp.data.needBegin == 1 && WeightConst_WeightHaveBegin==0)
                                {
                                    beep();
																		rt_sem_take(weight_lock, RT_WAITING_FOREVER);
                                    WeightConst_WeightBegin = WeightConst_WeightCur;
																		rt_sem_release(weight_lock);
																	  rt_sem_take(setTIME_lock, RT_WAITING_FOREVER);
																  	write_Flash("begintime", &TimeConst, sizeof(TimeConst));		
                                    rt_sem_release(setTIME_lock);																	
																	  write_Flash("beginweight", &WeightConst_WeightBegin, sizeof(WeightConst_WeightBegin));			
                                    getTargetWeight();
                                }
                                else if (pf_comp.data.pfsort != 0xFE && delayKeying == 0)
																{	
																		if (WeightConst_DELAYON == 0 && delayKeying == 0)
																		{		
																				rt_sem_release(delay_key_sem); 			
																				sendkey1(0xF3, ((XbeeConst_FRxBuf0_Remote[2] >> 4) & 0x0F));
																				WeightConst_AutoSingleNSecondPoint=0; // 防止自动跳转，重置自动记录指针
																				WeightConst_oksum = 0;
																			  WeightConst_joksum = 0;
																				WeightConst_allsum = 0;
																				button_state.b1=1;  //5秒内不可按键
																		}
															  }
                            }
                            else if (XbeeConst_FRxBuf0_Remote[4]==0x02 && button_state.b2==0) //收到2号键
                            {
                                if(!WeightConst_DELAYON>0)
																{
																		if (tsdb_recordcount('k')==0)
																				sendkey2(0xF4);
																}
//                                WeightConst_AutoSingleNSecondPoint=0; // 防止自动跳转，重置自动记录指针
//                                WeightConst_oksum = 0;
//                                WeightConst_allsum = 0;
                                button_state.b2=1;  //5秒内不可按键
                            }
                        }
                    }
                }
                XbeeConst_ReadNum0_Remote = 0; //循环计数清零
                XbeeConst_FrameLength0_Remote = 0;
            } else {
                XbeeConst_ReadNum0_Remote++;   //小于帧长度
                if (XbeeConst_ReadNum0_Remote>90)
                {
                    XbeeConst_ReadNum0_Remote = 0; //循环计数清零
                    XbeeConst_FrameLength0_Remote = 0;
                }
            }
            break;
        }
    }
}


static unsigned char Rec_watchTag[50];  //接收标签
unsigned char Rec_watchTag_point=0;  //接收标签
unsigned char ReadTag_state=0;   //读标签状态  0  没读或已读成功，1  开始读 ，2  正在读
unsigned char WriteTag_state=0;  //写标签状态  0  没写或已写成功，1  开始写 ，2  正在写

void ReadTag(unsigned char x) {  //发送标签
	unsigned char sendchar;
	sendchar=0x7E;
	HAL_UART_Transmit(&huart5, (uint8_t *)&sendchar, 1, 1);
	sendchar=0x03;
	HAL_UART_Transmit(&huart5, (uint8_t *)&sendchar, 1, 1);
	sendchar=XbeeConst_DeviceAddress;
	HAL_UART_Transmit(&huart5, (uint8_t *)&sendchar, 1, 1);
	sendchar=0xB2;
	HAL_UART_Transmit(&huart5, (uint8_t *)&sendchar, 1, 1);
	sendchar=x;
	HAL_UART_Transmit(&huart5, (uint8_t *)&sendchar, 1, 1);
	sendchar = 0x7E + 03 + XbeeConst_DeviceAddress + 0xB2 + x;
	HAL_UART_Transmit(&huart5, (uint8_t *)&sendchar, 1, 1);
	if (x==1) ReadTag_state=1;
	else ReadTag_state=0;
}

void WriteTag(void) {  //发送标签
	unsigned char sendchar;
	sendchar=0x7E;
	HAL_UART_Transmit(&huart5, (uint8_t *)&sendchar, 1, 1);
	sendchar=0x0A;
	HAL_UART_Transmit(&huart5, (uint8_t *)&sendchar, 1, 1);
	sendchar=XbeeConst_DeviceAddress;
	HAL_UART_Transmit(&huart5, (uint8_t *)&sendchar, 1, 1);
	sendchar=0xB1;
	HAL_UART_Transmit(&huart5, (uint8_t *)&sendchar, 1, 1);
	sendchar = 0x7E + 0x0A + XbeeConst_DeviceAddress + 0xB1;
	for (int i = 0; i < 8; i++)	{
		sendchar = sendchar + WeightConst_feed[i]; 
		HAL_UART_Transmit(&huart5, (uint8_t *)&WeightConst_feed[i], 1, 1);
	}
	HAL_UART_Transmit(&huart5, (uint8_t *)&sendchar, 1, 1);
	WriteTag_state = 1;
}

void watchTag(){
	unsigned char tempval, checksum = 0;
	tempval = rb_remove(rb_uart5);
	//HAL_UART_Transmit(&huart5, &tempval, 1,1);		
	if (tempval==0x7e || Rec_watchTag_point>49){   //头 过长回头
		Rec_watchTag_point=0;
	}
	Rec_watchTag[Rec_watchTag_point++] = tempval;
	if (Rec_watchTag_point>1 && Rec_watchTag_point>(Rec_watchTag[1]+2) ){  //符合长度
		Rec_watchTag_point=0;		
		for (int i = 0; i < Rec_watchTag[1]+2; i++)	
		{
			checksum = checksum + Rec_watchTag[i]; 
			if (checksum== Rec_watchTag[Rec_watchTag[1]+2] && Rec_watchTag[2]==XbeeConst_DeviceAddress)
			{//校验通过
				 if (Rec_watchTag[3]==0xB2)
				 {
					 if (Rec_watchTag[1]==2 && ReadTag_state==1)
						 {  //收到唤醒回复
						  ReadTag_state=2;
					 }else if (ReadTag_state==2){//收到标签
						  ReadTag_state=0;
						  for (int j = 0; j < 8; j++) {
                if (WeightConst_feed[j] != Rec_watchTag[4+j]) ReadTag_state=2;
              }
						  if (ReadTag_state ==0 && pf_comp.data.needBegin==1 && WeightConst_WeightHaveBegin==0)
              {
								beep();
								WeightConst_WeightBegin = WeightConst_WeightCur;
								//	FLKey_SaveQPOrder(pf_comp.data.pfsort);
								rt_sem_take(setTIME_lock, RT_WAITING_FOREVER);
								write_Flash("begintime", &TimeConst, sizeof(TimeConst));
								rt_sem_release(setTIME_lock);							
								write_Flash("beginweight", &WeightConst_WeightBegin, sizeof(WeightConst_WeightBegin)); 
								getTargetWeight();
								ReadTag(0);//关闭唤醒
              }
						  beep();					
					 }
				 }
				 else if (Rec_watchTag[3]==0xB1 && WriteTag_state>0){
					 if (Rec_watchTag[1]==2){  //收到写入回复
							WriteTag_state=2;
					 }else if(WriteTag_state==2){//写入成功
						  beep();
						  ReadTag(1);//kai唤醒
					 }
				 }
			}
	  }
	}
}


	
extern uint8_t rDataBuffer;
static void threadEmptyBuffer_entry(void *parameter)
{
		unsigned char tempval;
//	  if (isTag >0 )
//  	  HAL_UART_Receive_IT(&huart5, &rDataBuffer, 1); 
		while(1)
		{
			 rt_sem_take(thread_EmptyBuffer_sem, RT_WAITING_FOREVER);   //等待串口消息
			
			 while (rb_full_count(rb_usart1) > 0) {
				  ReadWeight(); 
			 }
			 
			 while (rb_full_count(rb_usart2) > 0) {
				 if (XbeeConst_UseAPI>0) {
            rb_push_insert(XbeeAPIQueue,rb_remove(rb_usart2));
            RX_API();
					}
					else
							rb_push_insert(XbeeQueue,rb_remove(rb_usart2));

					while(rb_full_count(XbeeQueue)>0) RX();
					while(rb_full_count(RemoteQueue)>0) RX_Remote();
			 }

			 while (rb_full_count(rb_usart3) > 0) {
				  if (XbeeConst_UseAPI>0) {
							if (WeightConst_BLE==1 || WeightConst_BLE== 3)
							{
									rb_push_insert(rb_usart1, rb_remove(rb_usart3));
							}
							else {
									rb_remove(rb_usart3);
							}	 //不能删除，用于清空3号串口
					}
					else
					{
							rb_push_insert(RemoteQueue, rb_remove(rb_usart3));
							while(rb_full_count(RemoteQueue)>0) RX_Remote();
					}
			 }

			 while (rb_full_count(rb_uart4) > 0) {
				 tempval = rb_remove(rb_uart4);  //继续存数据
         //if (tempval==0x59 && finish_send==0) finish_send=1;
			 }

			 while (rb_full_count(rb_uart5) > 0) {
				 watchTag();
			 }
		}
}

static rt_thread_t uart_tid = RT_NULL;
void threadUart_init(void)
{		  
    uart_tid = rt_thread_create("EmptyBuf",
                            threadEmptyBuffer_entry, RT_NULL,
                            0x500,
                            4, 5);

    /* 如果获得线程控制块，启动这个线程 */
    if (uart_tid != RT_NULL) rt_thread_startup(uart_tid);
}