{
  "method": "thing.event.property.post", 
  "id": "2241348", 
  "params": {
      "prop_float": 1.25, 
      "prop_int16": 4658, 
      "prop_bool": 1
  }, 
  "version": "1.0"
}

void TIM3_IRQHandler(void)
{
static uint32_t tim3_1ms_count = 0;
if (TIM_GetITStatus(TIM3, TIM_IT_Update) != RESET)
{
    tim3_1ms_count++;
    MilliTimer_Handler();
    if (tim3_1ms_count >= 1000)
    {
        DHCP_time_handler();
        DNS_time_handler();
        tim3_1ms_count = 0;
    }
    TIM_ClearITPendingBit(TIM3, TIM_IT_Update);
}
}

mqttconn mqtt_params = {
    .mqttHostUrl = "iot-06z00dbroeg8dx3.mqtt.iothub.aliyuncs.com",
    .server_ip = {
        0,
    },                                                                                                  /*Define the Connection Server IP*/
    .port = 1883,                                                                                       /*Define the connection service port number*/
    .clientid = "ieojgBm5q2c.W5100S_W5500|securemode=2,signmethod=hmacsha256,timestamp=1726890300625|", /*Define the client ID*/
    .username = "W5100S_W5500&ieojgBm5q2c",                                                             /*Define the user name*/
    .passwd = "8cdae1ce2d9391cfc4cf25539ef32b6d0b33558243aee7bc5aff073928a32568",                       /*Define user passwords*/
    .pubtopic = "/sys/ieojgBm5q2c/W5100S_W5500/thing/event/property/post",                              /*Define the publication message*/
    .subtopic = "/sys/ieojgBm5q2c/W5100S_W5500/thing/service/property/set",                             /*Define subscription messages*/
    .pubQoS = QOS0,                                                                                     /*Defines the class of service for publishing messages*/
};

/**
* @brief Initializing the MQTT client side
*
* Initialize the MQTT client side with the given parameters, including network configuration and MQTT connection parameters.
*
* @param sn socket number
* @param send_buf send buffer pointer
* @param recv_buf recv buffer pointer
*/
void mqtt_init(uint8_t sn, uint8_t *send_buf, uint8_t *recv_buf)
{
    wiz_NetInfo get_info = {0};
    wizchip_getnetinfo(&get_info);
    /* DNS parsing */
    if (do_dns(send_buf, (uint8_t *)mqtt_params.mqttHostUrl, mqtt_params.server_ip))
    {
        while (1)
        {
        }
    }
    NewNetwork(&n, sn);                                          /*Obtain network configuration information*/
    ConnectNetwork(&n, mqtt_params.server_ip, mqtt_params.port); /*Connect to the MQTT server*/
    MQTTClientInit(&c, &n, 1000, send_buf, MQTT_ETHERNET_MAX_SIZE, recv_buf, MQTT_ETHERNET_MAX_SIZE);
    data.will = willdata;
    data.willFlag = 0;                                                            /* will flag: If the will annotation bit is 0, the following will-related settings are invalid*/
    willdata.qos = mqtt_params.willQoS;                                           /* will QoS */
    willdata.topicName.lenstring.data = mqtt_params.willtopic;                    /* will topic */
    willdata.topicName.lenstring.len = strlen(willdata.topicName.lenstring.data); /* will topic len */
    willdata.message.lenstring.data = mqtt_params.willmsg;                        /* will message */
    willdata.message.lenstring.len = strlen(willdata.message.lenstring.data);     /* will message len */
    willdata.retained = 0;
    willdata.struct_version = 3;
    data.MQTTVersion = 4;
    data.clientID.cstring = mqtt_params.clientid;
    data.username.cstring = mqtt_params.username;
    data.password.cstring = mqtt_params.passwd;
    data.keepAliveInterval = 30;
    data.cleansession = 1;
}

//data结构体
typedef struct
{
  /** The eyecatcher for this structure.  must be MQTC. */
  char struct_id[4];
  /** The version number of this structure.  Must be 0 */
  int struct_version;
  /** Version of MQTT to be used.  3 = 3.1 4 = 3.1.1    */
  unsigned char MQTTVersion;
  MQTTString clientID;
  unsigned short keepAliveInterval;
  unsigned char cleansession;
  unsigned char willFlag;
  MQTTPacket_willOptions will;
  MQTTString username;
  MQTTString password;
} MQTTPacket_connectData;

//willdata结构体
/**
 * Defines the MQTT "Last Will and Testament" (LWT) settings for
 * the connect packet.
 */
typedef struct
{
	/** The eyecatcher for this structure.  must be MQTW. */
	char struct_id[4];
	/** The version number of this structure.  Must be 0 */
	int struct_version;
	/** The LWT topic to which the LWT message will be published. */
	MQTTString topicName;
	/** The LWT payload. */
	MQTTString message;
	/**
      * The retained flag for the LWT message (see MQTTAsync_message.retained).
      */
	unsigned char retained;
	/**
      * The quality of service setting for the LWT message (see
      * MQTTAsync_message.qos and @ref qos).
      */
	char qos;
} MQTTPacket_willOptions;

void do_mqtt(void)
{
  uint8_t ret;
  switch (run_status)
  {
  case CONN: {
      ret = MQTTConnect(&c, &data); /* Connect to the MQTT server */
      printf("Connect to the MQTT server: %d.%d.%d.%d:%d\r\n", mqtt_params.server_ip[0], mqtt_params.server_ip[1], mqtt_params.server_ip[2], mqtt_params.server_ip[3], mqtt_params.port);
      printf("Connected:%s\r\n\r\n", ret == SUCCESSS ? "success" : "failed");
      if (ret != SUCCESSS)
      {
          run_status = ERR;
      }
      else
      {
          run_status = SUB;
      }
      break;
  }
  case SUB: {
      ret = MQTTSubscribe(&c, mqtt_params.subtopic, mqtt_params.subQoS, messageArrived); /* Subscribe to Topics */
      printf("Subscribing to %s\r\n", mqtt_params.subtopic);
      printf("Subscribed:%s\r\n\r\n", ret == SUCCESSS ? "success" : "failed");
      if (ret != SUCCESSS)
      {
          run_status = ERR;
      }
      else
      {
          run_status = PUB_MESSAGE;
      }
      break;
  }
  case PUB_MESSAGE: {
      pubmessage.qos        = QOS0;
      pubmessage.payload    = "{\"id\":\"123\",\"version\":\"1.0\",\"params\":{\"CurrentTemperature\":26.6,},\"method\":\"thing.event.property.post\"}";
      pubmessage.payloadlen = strlen(pubmessage.payload);
      ret                   = MQTTPublish(&c, (char *)&(mqtt_params.pubtopic), &pubmessage); /* Publish message */
      if (ret != SUCCESSS)
      {
          run_status = ERR;
      }
      else
      {
          printf("publish:%s,%s\r\n\r\n", mqtt_params.pubtopic, (char *)pubmessage.payload);
          run_status = KEEPALIVE;
      }
      break;
  }
  case KEEPALIVE: {
      if (MQTTYield(&c, 30) != SUCCESSS) /* keepalive MQTT */
      {
          run_status = ERR;
      }
  }
  case RECV: {
      if (mqtt_recv_flag)
      {
          mqtt_recv_flag = 0;
          json_decode(mqtt_recv_msg);
      }
      break;
  }
  case ERR: /* Running error */
      printf("system ERROR!");
      delay_ms(1000);
      break;

  default:
      break;
  }
}

void messageArrived(MessageData *md)
{
    char topicname[64] = {0};
    char msg[512]      = {0};
    sprintf(topicname, "%.*s", (int)md->topicName->lenstring.len, md->topicName->lenstring.data);
    sprintf(msg, "%.*s", (int)md->message->payloadlen, (char *)md->message->payload);
    printf("recv:%s,%s\r\n\r\n", topicname, msg);
 
    mqtt_recv_flag = 1;
    memset(mqtt_recv_msg, 0, sizeof(mqtt_recv_msg));
    memcpy(mqtt_recv_msg, msg, strlen(msg));
}

void json_decode(char *msg)
{
    cJSON *jsondata = NULL;
    cJSON *params   = NULL;
    cJSON *LED      = NULL;
    jsondata        = cJSON_Parse(msg);
    if (jsondata == NULL)
    {
        printf("json parse fail.\r\n");
        return;
    }
    params = cJSON_GetObjectItem(jsondata, "params");
    LED    = cJSON_GetObjectItem(params, "LEDSwitch");
    if (LED->valueint == 1)
    {
        printf("LED ON\r\n");
    }
    else
    {
        printf("LED OFF\r\n");
    }
    cJSON_Delete(jsondata);
}