#include <SI4431.h> #include "SimRF.h" #include <Wire.h> #include <SPI.h> #include <I2C_graphical_LCD_display.h> I2C_graphical_LCD_display lcd; //    (0  ) #define LOCAL_ADDR (0) //  1:     #define RF_FUNC01 (1) //  2:    #define RF_FUNC02 (2) //    unsigned char RFTX_buffer[32]; //    unsigned char RFRX_buffer[32]; char i2a_buf[6]; /*   4- 16-    */ typedef struct { u16 Register0; u16 Register1; u16 Register2; u16 Register3; } tRemoteSensor; tRemoteSensor RemoteSensorStatus[2]; //      1  2 tRemoteSensor RemoteSensorCmd[2]; //        1  2 void print_P (const char* s) { char c; while ((c = pgm_read_byte(s++)) != 0) Serial.print(c); } u8 get_xor(u8* Src, u8 len) { u8 xoracc = 0; while (len--) { xoracc ^= *Src++; } return xoracc; } //   02       RemoteSensorCmd[]; void RFTX_FUNC02(u8 addr) { RemoteSensorCmd[addr -1].Register0 = RemoteSensorStatus[addr -1].Register0; RemoteSensorCmd[addr -1].Register1 = RemoteSensorStatus[addr -1].Register1; RemoteSensorCmd[addr -1].Register2 = RemoteSensorStatus[addr -1].Register2; RemoteSensorCmd[addr -1].Register3 = RemoteSensorStatus[addr -1].Register3; RFTX_buffer[0] = addr; //  RFTX_buffer[1] = LOCAL_ADDR; //  RFTX_buffer[2] = RF_FUNC02; //  02 u16* p16 = (u16*) &RFTX_buffer[3]; *p16++ = RemoteSensorCmd[addr -1].Register0; *p16++ = RemoteSensorCmd[addr -1].Register1; *p16++ = RemoteSensorCmd[addr -1].Register2; *p16++ = RemoteSensorCmd[addr -1].Register3; //      RFTX_buffer[11] = get_xor ((u8*)RFTX_buffer, 11); //     /*print_P(PSTR("\r\nData to TX: ")); for (u8 i = 0; i< 12; i++) { Serial.print((u8)RFTX_buffer[i], HEX); print_P(PSTR(",")); }*/ SI4431.TXData((u8*) RFTX_buffer, 12); } void RFRX_FUNC01(u8 SlaveAddr, u16* Payload) { RemoteSensorStatus [SlaveAddr - 1].Register0 = *Payload++; RemoteSensorStatus [SlaveAddr - 1].Register1 = *Payload++; RemoteSensorStatus [SlaveAddr - 1].Register2 = *Payload++; RemoteSensorStatus [SlaveAddr - 1].Register3 = *Payload++; } /**     * : * addr -     * len -    * pData -       SRAM * : * (0..127)    * -1  */ void RFRX_MASTER_PROCESS(u8 len) { s8 funccode; u8 SlaveAddr; //      if (len < 3) return; //print_P(PSTR("\r\n Dump:")); /*for (u8 i = 0; i< len; i++) { Serial.print(RFRX_buffer[i], HEX); print_P(PSTR(",")); i2a((u16)RFRX_buffer[i], i2a_buf); lcd.string(i2a_buf); lcd.string("-"); } */ SlaveAddr = RFRX_buffer[1]; //    if ((RFRX_buffer[0] == LOCAL_ADDR)&&(SlaveAddr != LOCAL_ADDR)) { //    MASTER    SLAVE ( >= 1) //  XOR // print_P(PSTR("\r\n Correct Addr!")); if (get_xor((u8*)RFRX_buffer, len - 1) == (u8) RFRX_buffer[len-1]) { funccode = RFRX_buffer[2]; //   switch (funccode) { case RF_FUNC01: { //     //print_P(PSTR("\r\nData from sensor: ")); //Serial.print(SlaveAddr, HEX); tRemoteSensor* pSensorData = (tRemoteSensor*)&RFRX_buffer[3]; //        //     s16 Temperature_x100 = (s16) (pSensorData-> Register0); u16 Humidity_x100 = pSensorData-> Register1; u16 Data1 = pSensorData-> Register2; u16 Data2 = pSensorData-> Register3; //   lcd.gotoxy (0, 16); lcd.string("Temperature: "); lcd.gotoxy (80, 16); if (Temperature_x100 < 0) { lcd.string("-"); Temperature_x100 = -Temperature_x100;//    } u16 Temp = Temperature_x100 / 100; //  i2a(Temp, i2a_buf); showString(i2a_buf); //lcd.string(i2a_buf); showString("."); i2a(Temperature_x100 - Temp * 100, i2a_buf); //  showString(i2a_buf); lcd.string("C "); //   lcd.gotoxy (0, 32); lcd.string("Humidity: "); lcd.gotoxy (80, 32); Temp = Humidity_x100 / 100; i2a(Temp, i2a_buf); showString(i2a_buf); showString("."); i2a(Humidity_x100 - Temp * 100, i2a_buf); showString(i2a_buf); lcd.string("% "); //    //i2a(Data, i2a_buf); //lcd.string(i2a_buf); //         01  02 if (SlaveAddr <= 0x02) { RFRX_FUNC01(SlaveAddr, (u16*) &RFRX_buffer[3]); } //   500  delay (500); //      02 RFTX_FUNC02(SlaveAddr); } break; case RF_FUNC02: { //      //      -    ,    print_P(PSTR("\r\nACK from sensor:")); Serial.print(SlaveAddr, HEX); } break; default: break; } } else print_P(PSTR("\r\n XOR error!")); } else print_P(PSTR("\r\n ADDR error!")); } //     01 void RFRX_RESP_FUNC02(t_cmd_servo* pcmd_servo) { s16 POS1, POS2, POS3, POS4; POS1 = pcmd_servo->POS1; POS2 = pcmd_servo->POS2; POS3 = pcmd_servo->POS3; POS4 = pcmd_servo->POS4; /*print_P(PSTR("\r\nServo function response OK!")); print_P(PSTR("\r\nPOS1:")); Serial.print(POS1, HEX); Serial.print(POS2, HEX); Serial.print(POS3, HEX); Serial.print(POS4, HEX); */ } void setup(){ u8 ItStatus1, ItStatus2; lcd.begin(0x20, 0, 10); Serial.begin(38400); u8 length; u8 temp8; delay (1000); SI4431.begin(); //   ,   SPI  /*for (u8 reg = 0; reg <=0x7f; reg++) { print_P(PSTR("\r\nReg:")); u8 c = SI4431.ReadRegister(reg); Serial.print(reg, HEX); print_P(PSTR(", ")); Serial.print(c, HEX); }*/ SI4431.Init(7); lcd.gotoxy(36, 0); lcd.string("I'm Ready!"); } void loop(){ u8 ItStatus1, ItStatus2; u8 len; // 2 : // a)     : 'ipkval' // )        CRC: 'icrcerror' SI4431.RXIRQEnable(); //           NIRQ SI4431.ReadStatus(&ItStatus1, &ItStatus2); /*   */ SI4431.RXEnable(); //    //   ,       CRC if(SI4431.IRQstate() == 0 ){ //   SI4431.RXDisable(); //           NIRQ SI4431.ReadStatus(&ItStatus1, &ItStatus2); //     CRC if( (ItStatus1 & 0x01) == 0x01 ){ print_P(PSTR("\r\n Received CRC Error!")); // FIFO  SI4431.FIFOReset(); //      /*TX_LED_SET RX_LED_SET delay(500); TX_LED_CLR RX_LED_CLR*/ } //       if( (ItStatus1 & 0x02) == 0x02 ){ print_P(PSTR("\r\n Received good packet! Len = ")); //    len = SI4431.RXPacketLen(); Serial.print(len, HEX); //,         if(len <= sizeof(RFRX_buffer)) { SI4431.RXData((u8 *)RFRX_buffer, len); //   RFRX_MASTER_PROCESS (len); } } // RX FIFO SI4431.FIFOReset(); //   SI4431.RXEnable(); } } void i2a( unsigned int i, char* pOut_buf ){ int ii; char int_buf[5]; for (ii=0; ii < 5; ){ int_buf[ii++] = '0'+ i % 10; i = i / 10; } do{ ii--; }while( (int_buf[ii] == '0') && (ii != 0) ); do { *pOut_buf++= int_buf[ii--]; } while (ii >= 0); *pOut_buf = 0x00; } 

 #include <SI4431.h> #include "SimRF.h" #include <avr/sleep.h> #include <avr/wdt.h> #include <SHT1x.h> #define dataPin 7 #define clockPin 6 SHT1x sht1x(dataPin, clockPin); //#define DEBUG_MODE //    (0  ) #define SLAVE_ADDR (1) //    //  1:    #define RF_FUNC01 (1) //  2:     #define RF_FUNC02 (2) //    unsigned char RFTX_buffer[32]; //    unsigned char RFRX_buffer[32]; unsigned char putch(unsigned char send_char) { while (!(UCSR0A & 0x20)); UDR0 = (unsigned char) send_char; while (!(UCSR0A & 0x20)); return(send_char); } /*      FLASH  */ void print_P (const char* s) { char c; while ((c = pgm_read_byte(s++)) != 0) putch(c); } /*  XOR    u8* Src -       u8 len -    */ u8 get_xor(u8* Src, u8 len){ u8 xoracc = 0; while (len--){ xoracc ^= *Src++; } return xoracc; } /*   01    u8 addr -   u8* Data -      u8 Len -    */ void RFTX_FUNC01(u8 addr, u8* Data, u8 Len){ RFTX_buffer[0] = addr; //  RFTX_buffer[1] = SLAVE_ADDR; //  RFTX_buffer[2] = 0x01; //  01 //       for (u8 i = 0 ; i < Len; i++){ RFTX_buffer[3+i] = *Data++; } //  XOR    RFTX_buffer[3 + Len] = get_xor ((u8*)RFTX_buffer, Len + 3); SI4431.TXData((u8*) RFTX_buffer, 3 + Len + 1); //       } /**    * : * addr -     * len -    * pData -       SRAM * : * (0..127)    * -1  */ s8 RFRX_PROCESS(u8 addr, u8 len, u8* pData){ s8 funccode; //      if (len < 3) return -1; if ((RFRX_buffer[0] == SLAVE_ADDR)&&(RFRX_buffer[1] == addr)) { //           if (get_xor((u8*)RFRX_buffer, len - 1) == RFRX_buffer[len-1]){ funccode = RFRX_buffer[2]; pData = (u8*) &RFRX_buffer[3]; return funccode; } else return -1; } else return -1; } /*       02 u8* PayloadData -    u8 PayloadLen -    */ void RFRX_RESP_FUNC02(u8* PayloadData, u8 PayloadLen){ //          #ifdef DEBUG_MODE for (u8 i = 0; i< PayloadLen; i++){ Serial.print(*PayloadData++, HEX); } #endif } //      void RFTX_ACK_FUNC02(u8 addr, u8* Data, u8 Len){ RFTX_buffer[0] = 0x00; //  RFTX_buffer[1] = SLAVE_ADDR; //  RFTX_buffer[2] = RF_FUNC02; //       for (u8 i = 0 ; i < Len; i++){ RFTX_buffer[3+i] = *Data++; } //  XOR    RFTX_buffer[3 + Len] = get_xor ((u8*)RFTX_buffer, Len+3); SI4431.TXData((u8*) RFTX_buffer, 3 + Len + 1); //       } u16 SensorData [4]; //   4 16    volatile unsigned char WDT_wake; volatile unsigned char SLEEP_TIME = 15; //volatile unsigned char WDT_counter; //    /*       */ ISR(WDT_vect) { static unsigned char WDT_counter; //    if (WDT_counter++ == SLEEP_TIME) { WDT_counter = 0; WDT_wake = 1; } //Serial.print(WDT_counter, HEX); asm ("WDR"); } void setup_WDT(void) { asm ("CLI"); asm ("WDR"); MCUSR &= ~(1<<WDRF); //   WDTCSR = (1 << WDCE)|(1<<WDE); WDTCSR = (1 << WDP2)|(1 << WDP1)|(1 << WDIE)|(1 << WDIF); //      1 .       asm ("SEI"); } void off_WDT(void){ asm ("CLI"); asm ("WDR"); MCUSR &= ~(1<<WDRF); //   WDTCSR = (1 << WDCE)|(1<<WDE)|(1 << WDIF); /* Turn off WDT */ WDTCSR = 0x00; asm ("SEI"); } void sys_sleep(void){ asm ("CLI"); ADCSRA &= ~(1 << ADEN); //   SMCR |= (1<<SE); //   power-down asm ("SEI"); asm ("SLEEP"); } void sys_wake(void){ //     } void RF_sleep (void){ u8 ItStatus1, ItStatus2; //           NIRQ SI4431.ReadStatus(&ItStatus1, &ItStatus2); SI4431.WriteRegister(0x08, 0x03); // FIFO SI4431.WriteRegister(0x08, 0x00); SI4431.WriteRegister(0x07, 0x00); //   } void setup(){ Serial.begin(38400); delay (1000); u8 ItStatus1, ItStatus2; u8 length; u8 temp8; #ifdef DEBUG_MODE print_P (PSTR("\r\nHello!")); #endif delay (100); SI4431.begin(); #ifdef DEBUG_MODE //   ,   SPI  for (u8 reg = 0; reg <=0x7f; reg++){ print_P(PSTR("\r\nReg:")); u8 c = SI4431.ReadRegister (reg); Serial.print(reg, HEX); print_P(PSTR(", ")); Serial.print(c, HEX); } #endif SI4431.Init(7); #ifdef DEBUG_MODE print_P(PSTR("\r\nRadio initialisation is OK")); #endif delay (1000); setup_WDT(); SMCR = (1<<SE)|(1<<SM1); //   power-down sys_sleep(); } void loop(){ u8 ItStatus1, ItStatus2; unsigned long Timer; if (WDT_wake){ Timer = 0; WDT_wake = 0; //    N  //    off_WDT(); //digitalWrite(13, HIGH); //   (   ) #ifdef DEBUG_MODE print_P(PSTR("\r\n WAKE UP!")); #endif // 1)   ,      SHT11x float Temp = sht1x.readTemperatureC(); s16 Temp_x100 = (s16) (Temp * 100.0); //   100.0 SensorData[0] = (u16) Temp_x100; float Humidity = sht1x.readHumidity(); u16 Humidity_x100 = (s16) (Humidity * 100.0); //   100.0 SensorData[1] = Humidity_x100; SensorData[2] = 0; SensorData[3] = 0; // 2) ,         // 3) ,      // 4)      0 (   ...     ) for (u8 TXcnt = 0; TXcnt< 4; TXcnt++) { #ifdef DEBUG_MODE print_P(PSTR("\r\n TX to MASTER #")); #endif Serial.print(TXcnt + 1, DEC); RFTX_FUNC01(0x00, (u8*) SensorData, 8); //    0 8     // 4)       0      } // 5)     RX //         // 2 : // a)     : 'ipkval' // )        CRC: 'icrcerror' SI4431.RXIRQEnable(); //           NIRQ SI4431.ReadStatus(&ItStatus1, &ItStatus2); // FIFO  SI4431.FIFOReset(); /*   */ SI4431.RXEnable(); // 6)       1  #ifdef DEBUG_MODE print_P(PSTR("\r\n Wait Resp")); #endif Timer = 0; #define RESP_TIMEOUT (65535 * 32) while (Timer < RESP_TIMEOUT){ //asm ("WDR"); if(SI4431.IRQstate() == 0 ) { //     CRC //   SI4431.RXDisable(); //           NIRQ SI4431.ReadStatus(&ItStatus1, &ItStatus2); //     CRC if( (ItStatus1 & 0x01) == 0x01 ) { #ifdef DEBUG_MODE print_P(PSTR("\r\n RX CRC Error!")); #endif // FIFO  SI4431.FIFOReset(); //      break; //      } else if( (ItStatus1 & 0x02) == 0x02 ) { //       #ifdef DEBUG_MODE print_P(PSTR("\r\n RX packet Len = ")); #endif //    u8 len = SI4431.RXPacketLen(); #ifdef DEBUG_MODE Serial.print(len, HEX); #endif //,         if(len <= sizeof(RFRX_buffer)) { SI4431.RXData((u8 *)RFRX_buffer, len); //   s8 funccode = RFRX_PROCESS (0x00, len, (u8*)RFRX_buffer); switch (funccode) { case RF_FUNC02: { //     ! #ifdef DEBUG_MODE print_P(PSTR("\r\n MASTER RESPONSE!")); #endif u8* PayloadData = (u8*) &RFRX_buffer[3]; //   u8 PayloadLen = len - 4; //   RFRX_RESP_FUNC02(PayloadData, PayloadLen); //  // 7)   ,        //       for (u8 TXcnt = 0; TXcnt< 4; TXcnt++) { #ifdef DEBUG_MODE print_P(PSTR("\r\n ACK MASTER RESPONSE!")); #endif RFTX_ACK_FUNC02(0x00, PayloadData, PayloadLen); } } break; default: #ifdef DEBUG_MODE print_P(PSTR("\r\nInvalid RX packet!")); #endif break; } } } break; //      } else { Timer++; } } #ifdef DEBUG_MODE if (Timer == RESP_TIMEOUT) print_P(PSTR("\r\n Response Timeout!")); print_P(PSTR("\r\n SLEEP...")); #endif // 8)      RF_sleep(); setup_WDT(); //digitalWrite(13, LOW); } // 9)     ,    N    // 10)  ,   . 1. sys_sleep(); }