Tuya adapter V2 arduino source code - RS485 relay controller KC868-H32BS

Code:
#include <ModbusMaster.h>

#include <Arduino.h>

#include <TuyaWifi.h>

#include "HardwareSerial.h"

//---------RS485 setting

#define DEBUG   1



#define SERIAL_BAUD   9600

#define RX_PIN    32

#define TX_PIN    33

#define ADAPT485_NUM  2

#define SLAVE_ADDR  1

#define READ_ADDR  0 

#define READ_NUM   32  



/* Current device DP values */

bool rt_coils_status[32] = {0}; 



HardwareSerial My485Serial(ADAPT485_NUM);

ModbusMaster node;

uint16_t rcv_buf[READ_NUM>>4] = {0};

   

static void ReadEmeterRegs(void)

{

  uint32_t read_tmp = 0;

   

  uint8_t result = node.readCoils(READ_ADDR, READ_NUM);

  if (result == node.ku8MBSuccess) {//if communicate successful then

        

    for (uint8_t i = 0; i < 2; i++)

    {

      rcv_buf[i] = node.getResponseBuffer(i);

      for(uint8_t j = 0; j < 16; j++)

      {

        if(j<8) rt_coils_status[i*16 + j+8] = (rcv_buf[1-i]&(1<<j))?true:false;

        else rt_coils_status[i*16 + j - 8] = (rcv_buf[1-i]&(1<<j))?true:false;

      }

    } 

    

    #if DEBUG

    Serial1.print("Get switch[0..31] value is");

    Serial1.print(":<0x");

    Serial1.print(rcv_buf[0],HEX);

    Serial1.print(rcv_buf[1],HEX);

    Serial1.println("> ");

    #endif

     

  }

  else 

  {

    node.clearResponseBuffer();

  }



  delay(100);

}



//---RS485 setting end----



TuyaWifi my_device;







/* Current LED status */

unsigned char led_state = 0;

/* Connect network button pin */

int key_pin = 25;





/* Data point define */

typedef enum

{

  DPID_SWITCH01 = 1,

  DPID_SWITCH02,DPID_SWITCH03,

  DPID_SWITCH04,DPID_SWITCH05,DPID_SWITCH06,

  DPID_SWITCH07 = 113,

  DPID_SWITCH08,DPID_SWITCH09,DPID_SWITCH10,

  DPID_SWITCH11,DPID_SWITCH12,DPID_SWITCH13,

  DPID_SWITCH14,DPID_SWITCH15,DPID_SWITCH16,

  DPID_SWITCH17,DPID_SWITCH18,DPID_SWITCH19,

  DPID_SWITCH20,DPID_SWITCH21,DPID_SWITCH22,

  DPID_SWITCH23,DPID_SWITCH24,DPID_SWITCH25,

  DPID_SWITCH26,DPID_SWITCH27,DPID_SWITCH28,

  DPID_SWITCH29,DPID_SWITCH30,DPID_SWITCH31,

  DPID_SWITCH32,

}H32BS_DPID_DEF;

 

/*const unsigned char dpid_arr[32] = {

  1,2,3,4,5,6,

  113,114,115,116,117,118,119,120,

  121,122,123,124,125,126,127,128,

  129,130,131,132,133,134,135,136,

  137,138,

};*/



#define LED_WiFi  26

//#define LED_User  33







/* Stores all DPs and their types. PS: array[][0]:dpid, array[][1]:dp type. 

 *                                     dp type(TuyaDefs.h) : DP_TYPE_RAW, DP_TYPE_BOOL, DP_TYPE_VALUE, DP_TYPE_STRING, DP_TYPE_ENUM, DP_TYPE_BITMAP

*/

unsigned char dp_array[][2] =

{ 

  {DPID_SWITCH01, DP_TYPE_BOOL},{DPID_SWITCH02, DP_TYPE_BOOL},

  {DPID_SWITCH03, DP_TYPE_BOOL},{DPID_SWITCH04, DP_TYPE_BOOL},

  {DPID_SWITCH05, DP_TYPE_BOOL},{DPID_SWITCH06, DP_TYPE_BOOL},

  {DPID_SWITCH07, DP_TYPE_BOOL},{DPID_SWITCH08, DP_TYPE_BOOL},



  {DPID_SWITCH09, DP_TYPE_BOOL},{DPID_SWITCH10, DP_TYPE_BOOL},

  {DPID_SWITCH11, DP_TYPE_BOOL},{DPID_SWITCH12, DP_TYPE_BOOL},

  {DPID_SWITCH13, DP_TYPE_BOOL},{DPID_SWITCH14, DP_TYPE_BOOL},

  {DPID_SWITCH15, DP_TYPE_BOOL},{DPID_SWITCH16, DP_TYPE_BOOL},



  {DPID_SWITCH17, DP_TYPE_BOOL},{DPID_SWITCH18, DP_TYPE_BOOL},

  {DPID_SWITCH19, DP_TYPE_BOOL},{DPID_SWITCH20, DP_TYPE_BOOL},

  {DPID_SWITCH21, DP_TYPE_BOOL},{DPID_SWITCH22, DP_TYPE_BOOL},

  {DPID_SWITCH23, DP_TYPE_BOOL},{DPID_SWITCH24, DP_TYPE_BOOL},



  {DPID_SWITCH25, DP_TYPE_BOOL},{DPID_SWITCH26, DP_TYPE_BOOL},

  {DPID_SWITCH27, DP_TYPE_BOOL},{DPID_SWITCH28, DP_TYPE_BOOL},

  {DPID_SWITCH29, DP_TYPE_BOOL},{DPID_SWITCH30, DP_TYPE_BOOL},

  {DPID_SWITCH31, DP_TYPE_BOOL},{DPID_SWITCH32, DP_TYPE_BOOL},

};



unsigned char pid[] = {"3ocztklfu3q32jab"}; ////change pid here....

unsigned char mcu_ver[] = {"1.0.0"};



/* last time */

unsigned long last_time = 0;



/**

 * @description: DP download callback function.

 * @param {unsigned char} dpid

 * @param {const unsigned char} value

 * @param {unsigned short} length

 * @return {unsigned char}

 */

unsigned char dp_process(unsigned char dpid,const unsigned char value[], unsigned short length)

{

  int16_t index_out_coil = -1;

  unsigned char get_down_cmd = false;

  

  for(int16_t i=0;i<32;i++)

  {

    if(dpid == dp_array[i][0]) 

    {

      index_out_coil = i;

      break;

    }

  }

  if(index_out_coil < 0) return TY_ERROR;



  get_down_cmd = my_device.mcu_get_dp_download_data(dpid,value,length);



  Serial1.print("Rcv Command:<dpid,");

  Serial1.print(dpid,DEC);

  Serial1.print(" value,");

  Serial1.print(value[0],HEX);

  Serial1.print(" len,");

  Serial1.println(length,HEX);

  Serial1.println("> ");

    

  



  #if DEBUG

    Serial1.print("get_down_cmd value is:<");

    Serial1.print(get_down_cmd,DEC);  

    Serial1.println("> ");

    Serial1.print("Node WriteCoilAddr<");

    Serial1.print(index_out_coil,DEC);

    Serial1.print("> ");

  #endif



  delay(100);

  uint8_t result = node.writeSingleCoil(index_out_coil, value[0]);

  #if DEBUG

    Serial1.print(" result:<");

    Serial1.print(result,DEC);  

    Serial1.println("> ");

  #endif



  delay(100);

  my_device.mcu_dp_update(dpid, value, length);

  return TY_SUCCESS;

}



void setup() 

{



  My485Serial.begin(SERIAL_BAUD, SERIAL_8N1, RX_PIN, TX_PIN); //RS485 serial port

  node.begin(SLAVE_ADDR,My485Serial);

  Serial.begin(9600,SERIAL_8N1,22,19);  //Tuya module serial port

  Serial1.begin(115200,SERIAL_8N1,3,1);   //USB serial port



  

  // Serial with tuyawifi

  

  



  //Initialize led port, turn off led.

  pinMode(LED_WiFi, OUTPUT);

  digitalWrite(LED_WiFi, LOW);



/*  pinMode(LED_User, OUTPUT);

  digitalWrite(LED_User, LOW);*/



  //Initialize networking keys.

  pinMode(key_pin, INPUT_PULLUP);



  //Enter the PID and MCU software version

  my_device.init(pid, mcu_ver);

  //incoming all DPs and their types array, DP numbers

  my_device.set_dp_cmd_total(dp_array, 2);

  //register DP download processing callback function

  my_device.dp_process_func_register(dp_process);

  //register upload all DP callback function

  my_device.dp_update_all_func_register(dp_update_all);

  

  //delay(300);

  last_time = millis();

}



void loop() 

{

  ReadEmeterRegs();  // read RS485 sensor

  my_device.uart_service();



  //Enter the connection network mode when Pin7 is pressed.

  if (digitalRead(key_pin) == LOW) {

    delay(80);

    if (digitalRead(key_pin) == LOW) {

      my_device.mcu_set_wifi_mode(SMART_CONFIG);

    }

  }

  /* LED blinks when network is being connected */

  if ((my_device.mcu_get_wifi_work_state() != WIFI_LOW_POWER) && (my_device.mcu_get_wifi_work_state() != WIFI_CONN_CLOUD) && (my_device.mcu_get_wifi_work_state() != WIFI_SATE_UNKNOW)) {

    if (millis()- last_time >= 500) {

      last_time = millis();



      if (led_state == LOW) {

        led_state = HIGH;

      } else {

        led_state = LOW;

      }

      digitalWrite(LED_WiFi, led_state);

    }

  }



  /* report the temperature and humidity */

  if ((my_device.mcu_get_wifi_work_state() == WIFI_CONNECTED) || 

      (my_device.mcu_get_wifi_work_state() == WIFI_CONN_CLOUD)) {

    dp_update_all();

  }



  delay(500);

}

 

static bool coils_old_status[32] = {false};



unsigned char tmp_cmd = 0;

static void CompareAndReport(void)

{

  for(int16_t i=0;i<32;i++)

  {

    if(coils_old_status[i] != rt_coils_status[i])

    {

      coils_old_status[i] = rt_coils_status[i];

      tmp_cmd = rt_coils_status[i]?1:0;

      #if 0

      Serial1.print("Changed happed:<dpid,");

      Serial1.print(dp_array[i][0],DEC);

      Serial1.println("> ");

      #endif

      my_device.mcu_dp_update(dp_array[i][0],tmp_cmd, 1);

      delay(10); 

      //break;

    }

  } 

}

/**

 * @description: Upload all DP status of the current device.

 * @param {*}

 * @return {*}

 */

void dp_update_all(void)

{ 

  CompareAndReport();

  

}