GC19038/User/extend_master.c

#include "global.h"


#define ALARM_REG user_datas[100]

static const unsigned char  CRCTblHi[] = {
    0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0,
    0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
    0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0,
    0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
    0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1,
    0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41,
    0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1,
    0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
    0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0,
    0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40,
    0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1,
    0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
    0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0,
    0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40,
    0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0,
    0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
    0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0,
    0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
    0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0,
    0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
    0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0,
    0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40,
    0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1,
    0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
    0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0,
    0x80, 0x41, 0x00, 0xC1, 0x81, 0x40
};

static const unsigned char CRCTblLo[] = {
    0x00, 0xC0, 0xC1, 0x01, 0xC3, 0x03, 0x02, 0xC2, 0xC6, 0x06,
    0x07, 0xC7, 0x05, 0xC5, 0xC4, 0x04, 0xCC, 0x0C, 0x0D, 0xCD,
    0x0F, 0xCF, 0xCE, 0x0E, 0x0A, 0xCA, 0xCB, 0x0B, 0xC9, 0x09,
    0x08, 0xC8, 0xD8, 0x18, 0x19, 0xD9, 0x1B, 0xDB, 0xDA, 0x1A,
    0x1E, 0xDE, 0xDF, 0x1F, 0xDD, 0x1D, 0x1C, 0xDC, 0x14, 0xD4,
    0xD5, 0x15, 0xD7, 0x17, 0x16, 0xD6, 0xD2, 0x12, 0x13, 0xD3,
    0x11, 0xD1, 0xD0, 0x10, 0xF0, 0x30, 0x31, 0xF1, 0x33, 0xF3,
    0xF2, 0x32, 0x36, 0xF6, 0xF7, 0x37, 0xF5, 0x35, 0x34, 0xF4,
    0x3C, 0xFC, 0xFD, 0x3D, 0xFF, 0x3F, 0x3E, 0xFE, 0xFA, 0x3A,
    0x3B, 0xFB, 0x39, 0xF9, 0xF8, 0x38, 0x28, 0xE8, 0xE9, 0x29,
    0xEB, 0x2B, 0x2A, 0xEA, 0xEE, 0x2E, 0x2F, 0xEF, 0x2D, 0xED,
    0xEC, 0x2C, 0xE4, 0x24, 0x25, 0xE5, 0x27, 0xE7, 0xE6, 0x26,
    0x22, 0xE2, 0xE3, 0x23, 0xE1, 0x21, 0x20, 0xE0, 0xA0, 0x60,
    0x61, 0xA1, 0x63, 0xA3, 0xA2, 0x62, 0x66, 0xA6, 0xA7, 0x67,
    0xA5, 0x65, 0x64, 0xA4, 0x6C, 0xAC, 0xAD, 0x6D, 0xAF, 0x6F,
    0x6E, 0xAE, 0xAA, 0x6A, 0x6B, 0xAB, 0x69, 0xA9, 0xA8, 0x68,
    0x78, 0xB8, 0xB9, 0x79, 0xBB, 0x7B, 0x7A, 0xBA, 0xBE, 0x7E,
    0x7F, 0xBF, 0x7D, 0xBD, 0xBC, 0x7C, 0xB4, 0x74, 0x75, 0xB5,
    0x77, 0xB7, 0xB6, 0x76, 0x72, 0xB2, 0xB3, 0x73, 0xB1, 0x71,
    0x70, 0xB0, 0x50, 0x90, 0x91, 0x51, 0x93, 0x53, 0x52, 0x92,
    0x96, 0x56, 0x57, 0x97, 0x55, 0x95, 0x94, 0x54, 0x9C, 0x5C,
    0x5D, 0x9D, 0x5F, 0x9F, 0x9E, 0x5E, 0x5A, 0x9A, 0x9B, 0x5B,
    0x99, 0x59, 0x58, 0x98, 0x88, 0x48, 0x49, 0x89, 0x4B, 0x8B,
    0x8A, 0x4A, 0x4E, 0x8E, 0x8F, 0x4F, 0x8D, 0x4D, 0x4C, 0x8C,
    0x44, 0x84, 0x85, 0x45, 0x87, 0x47, 0x46, 0x86, 0x82, 0x42,
    0x43, 0x83, 0x41, 0x81, 0x80, 0x40
};


/**
 * 计算累加和校验
 * 
 * @author LXZ (2018-12-03)
 * 
 * @param dat 
 * @param length 
 * 
 * @return unsigned char 
 */
static unsigned short calc_crc(unsigned char *dat, int length)
{
    unsigned char lo = 0xff, hi = 0xff;
    unsigned char index = 0;

    while (length > 0)
    {
        length--;
        index = hi ^ (*dat);
        hi = lo ^ CRCTblHi[index];
        lo = CRCTblLo[index];
        dat++;
    }
    return 0x0100 * lo + hi;
}


#define EXTEND_MASTER_UART    0
//下载包之间的间隔
static sw_timer_t timer;

/**
 * 扩展设备初始化
 * 
 * @author lxz 
 * 
 * @param void 
 */
void extend_master_init(void)
{
#if USE_EXTEND_INOUTPUT
    //速度500K
    int value = 9600;
    hw_dma_uart_control(EXTEND_MASTER_UART, UART_CTRL_SET_SPEED, &value);
    //2ms的接收判断时间，如果程序处理量比较庞大
    value = 2000;
    hw_dma_uart_control(EXTEND_MASTER_UART, UART_CTRL_SET_RDFIN_TIME, &value);
    //5ms的发送间隔时间，如果程序处理量比较庞大，那么建议这个时间
    value = 5000;
    hw_dma_uart_control(EXTEND_MASTER_UART, UART_CTRL_SET_WRFIN_TIME, &value);
    
    sw_timer_start(&timer,0,0);
#endif
}


#if USE_EXTEND_INOUTPUT
//发送缓冲
static unsigned char up_buffer[256];
//接收缓冲
static unsigned char down_buffer[256];
//下载步
static char down_step = 0;
//上传步
static char up_step = 0;
#endif
/**
 * 扩展协议主站运行
 * 
 * @author lxz 
 * 
 * @param void 
 */
    int length = 0;
void extend_master_run(void)
{
#if USE_EXTEND_INOUTPUT

    int n = 0;
    unsigned short crc = 0;

    switch (down_step)
    {
    case 0:
        down_buffer[length++] = 0x3A;
        down_buffer[length++] = 0x10;
        down_buffer[length++] = (EXTEND_IO_OUTPUT_NUMBER + 7) / 8;
        while (n < (EXTEND_IO_OUTPUT_NUMBER + 7) / 8)
        {
            down_buffer[length++] = io_outputs[3 + n].value;
            n++;
        }
        crc = calc_crc(down_buffer, length);
        down_buffer[length++] = crc;
        down_buffer[length++] = crc >> 8;

        down_step++;
        hw_dma_uart_begin_write(EXTEND_MASTER_UART, (const char *)down_buffer, length);
        
        break;
    case 1:
        //等待发送完成
        if (hw_dma_uart_write_finish(EXTEND_MASTER_UART))
        {
            down_step = 0;
        }
        break;
    }

    switch (up_step)
    {
    case 0:
        up_step++;
        hw_dma_uart_begin_read(EXTEND_MASTER_UART, up_buffer, sizeof(up_buffer));
        break;
    case 1:
        length = hw_dma_uart_read_finish(EXTEND_MASTER_UART);
        if (length > 0)
        {
            if (calc_crc(up_buffer,length) == 0 && 
                up_buffer[0] == 0x3A && 
                up_buffer[1] == 0x10)
            {
                n = 0;
               
                while (n + 1 < up_buffer[2])
                {
                    io_inputs[4 + n].value = up_buffer[4 + n];
                    n++;
                }
                //100ms没收到包，说明断线
                sw_timer_start(&timer,0,500000);
                
                if (up_buffer[3])
                {
                    //说明扩展没有收到包
                  ALARM_REG = 16; 
                    //这里需要处理报警
                }
                else if(ALARM_REG==16)
                {
                  ALARM_REG=0;
                }
                //up_buffer[
            }
            
            up_step = 0;
        }
        else if (sw_timer_expire(&timer))
        {
            //接收超时，扩展没上传，报警
          ALARM_REG = 18;
        }
        else
        {
          if(ALARM_REG==18)ALARM_REG = 0;      
        }
        break;
    }
    
#endif    
    
}