iot_water_monitor_v2
Dependencies: easy-connect-v16 Watchdog FP MQTTPacket RecordType-v-16 watersenor_and_temp_code
Simple-MQTT/SimpleMQTT.h@50:5a19fc4b41d9, 2018-03-18 (annotated)
- Committer:
- DuyLionTran
- Date:
- Sun Mar 18 17:54:50 2018 +0000
- Revision:
- 50:5a19fc4b41d9
- Parent:
- 48:a7ed665844cd
- Child:
- 52:5546fa1b67b5
* version 2.8.5 03-19-2018: Set time to turn on/off the relay
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
DuyLionTran | 32:8226837c56ae | 1 | #ifndef __SIMPLEMQTT_H__ |
DuyLionTran | 32:8226837c56ae | 2 | #define __SIMPLEMQTT_H__ |
DuyLionTran | 32:8226837c56ae | 3 | |
DuyLionTran | 32:8226837c56ae | 4 | /*************************************************************** |
DuyLionTran | 32:8226837c56ae | 5 | * Includes |
DuyLionTran | 32:8226837c56ae | 6 | ***************************************************************/ |
DuyLionTran | 32:8226837c56ae | 7 | #include "easy-connect.h" |
DuyLionTran | 32:8226837c56ae | 8 | #include "MQTTClient.h" |
DuyLionTran | 32:8226837c56ae | 9 | #include "NDefLib/NDefNfcTag.h" |
DuyLionTran | 32:8226837c56ae | 10 | #include "NDefLib/RecordType/RecordURI.h" |
DuyLionTran | 32:8226837c56ae | 11 | #include "MQTTNetwork.h" |
DuyLionTran | 32:8226837c56ae | 12 | #include "MQTTmbed.h" |
DuyLionTran | 32:8226837c56ae | 13 | |
DuyLionTran | 32:8226837c56ae | 14 | #include "Json.h" |
DuyLionTran | 32:8226837c56ae | 15 | #include "CommandExecution.h" |
DuyLionTran | 32:8226837c56ae | 16 | #include "flash_programming.h" |
DuyLionTran | 32:8226837c56ae | 17 | /*************************************************************** |
DuyLionTran | 32:8226837c56ae | 18 | * Definitions |
DuyLionTran | 32:8226837c56ae | 19 | ***************************************************************/ |
DuyLionTran | 32:8226837c56ae | 20 | // Configuration values needed to connect to IBM IoT Cloud |
DuyLionTran | 32:8226837c56ae | 21 | #define ORG MQTT_ORG_ID // connect to ORG.internetofthings.ibmcloud.com/ For a registered connection, replace with your org |
DuyLionTran | 32:8226837c56ae | 22 | #define ID MQTT_DEVICE_ID // For a registered connection is your device id |
DuyLionTran | 32:8226837c56ae | 23 | #define AUTH_TOKEN MQTT_DEVICE_PASSWORD // For a registered connection is a device auth-token |
DuyLionTran | 32:8226837c56ae | 24 | #define DEFAULT_TYPE_NAME MQTT_DEVICE_TYPE // For a registered connection is device type |
DuyLionTran | 32:8226837c56ae | 25 | #define AUTH_METHOD MQTT_USERNAME |
DuyLionTran | 32:8226837c56ae | 26 | |
DuyLionTran | 32:8226837c56ae | 27 | #define TYPE DEFAULT_TYPE_NAME // For a registered connection, replace with your type |
DuyLionTran | 32:8226837c56ae | 28 | #define IBM_IOT_PORT MQTT_PORT |
DuyLionTran | 32:8226837c56ae | 29 | |
DuyLionTran | 43:dcde0e66874a | 30 | #define MQTT_MAX_PACKET_SIZE 450 |
DuyLionTran | 43:dcde0e66874a | 31 | #define MQTT_MAX_PAYLOAD_SIZE 350 |
DuyLionTran | 32:8226837c56ae | 32 | |
DuyLionTran | 32:8226837c56ae | 33 | /*************************************************************** |
DuyLionTran | 32:8226837c56ae | 34 | * Variables |
DuyLionTran | 32:8226837c56ae | 35 | ***************************************************************/ |
DuyLionTran | 32:8226837c56ae | 36 | typedef enum { |
DuyLionTran | 32:8226837c56ae | 37 | ADC_VALUE = 0, |
DuyLionTran | 32:8226837c56ae | 38 | SENSOR_VALUE, |
DuyLionTran | 32:8226837c56ae | 39 | RELAY_STATE, |
DuyLionTran | 32:8226837c56ae | 40 | CONFIG_VALUE |
DuyLionTran | 32:8226837c56ae | 41 | } UploadType; |
DuyLionTran | 39:a5ee98bd0050 | 42 | |
DuyLionTran | 39:a5ee98bd0050 | 43 | typedef enum { |
DuyLionTran | 39:a5ee98bd0050 | 44 | CONTROL_CMD = 0, |
DuyLionTran | 39:a5ee98bd0050 | 45 | READ_CMD, |
DuyLionTran | 39:a5ee98bd0050 | 46 | SETUP_CMD |
DuyLionTran | 39:a5ee98bd0050 | 47 | } CommandType; |
DuyLionTran | 32:8226837c56ae | 48 | |
DuyLionTran | 32:8226837c56ae | 49 | struct UploadValue { |
DuyLionTran | 43:dcde0e66874a | 50 | float ADC_TEMPVal; |
DuyLionTran | 32:8226837c56ae | 51 | float ADC_DOVal; |
DuyLionTran | 32:8226837c56ae | 52 | |
DuyLionTran | 43:dcde0e66874a | 53 | float SENSOR_TEMPVal; |
DuyLionTran | 36:d0b628087ac8 | 54 | float SENSOR_DOVal; |
DuyLionTran | 32:8226837c56ae | 55 | |
DuyLionTran | 33:5b90257d2d57 | 56 | uint8_t RELAY_State_1; |
DuyLionTran | 33:5b90257d2d57 | 57 | uint8_t RELAY_State_2; |
DuyLionTran | 34:601effb7b7fe | 58 | uint8_t RELAY_State_3; |
DuyLionTran | 34:601effb7b7fe | 59 | |
DuyLionTran | 33:5b90257d2d57 | 60 | uint32_t CONFIG_Time; |
DuyLionTran | 32:8226837c56ae | 61 | |
DuyLionTran | 32:8226837c56ae | 62 | uint8_t CONFIG_Mode; |
DuyLionTran | 43:dcde0e66874a | 63 | uint8_t CONFIG_OxyThreshold; |
DuyLionTran | 43:dcde0e66874a | 64 | uint8_t CONFIG_TemperatureThreshold; |
DuyLionTran | 50:5a19fc4b41d9 | 65 | uint16_t CONFIG_UploadInterval; /* in second */ |
DuyLionTran | 50:5a19fc4b41d9 | 66 | |
DuyLionTran | 50:5a19fc4b41d9 | 67 | uint32_t CONFIG_AlarmTime; |
DuyLionTran | 50:5a19fc4b41d9 | 68 | uint8_t CONFIG_SetRelayState_1; |
DuyLionTran | 50:5a19fc4b41d9 | 69 | uint8_t CONFIG_SetRelayState_2; |
DuyLionTran | 32:8226837c56ae | 70 | } UploadValue; |
DuyLionTran | 32:8226837c56ae | 71 | |
DuyLionTran | 32:8226837c56ae | 72 | char *projectName = "WaterMonitor"; |
DuyLionTran | 32:8226837c56ae | 73 | static char id[30] = ID; // mac without colons |
DuyLionTran | 32:8226837c56ae | 74 | static char org[12] = ORG; |
DuyLionTran | 32:8226837c56ae | 75 | static char type[30] = TYPE; |
DuyLionTran | 32:8226837c56ae | 76 | static char auth_token[30] = AUTH_TOKEN; // Auth_token is only used in non-quickstart mode |
DuyLionTran | 32:8226837c56ae | 77 | static int connack_rc = 0; // MQTT connack return code |
DuyLionTran | 33:5b90257d2d57 | 78 | static bool wifiConnected = true; |
DuyLionTran | 32:8226837c56ae | 79 | static bool netConnecting = false; |
DuyLionTran | 32:8226837c56ae | 80 | static bool mqttConnecting = false; |
DuyLionTran | 32:8226837c56ae | 81 | static bool netConnected = false; |
DuyLionTran | 32:8226837c56ae | 82 | static bool connected = false; |
DuyLionTran | 32:8226837c56ae | 83 | static int retryAttempt = 0; |
DuyLionTran | 32:8226837c56ae | 84 | static int connectTimeout = 1000; |
DuyLionTran | 32:8226837c56ae | 85 | uint16_t commandID = 0; |
DuyLionTran | 32:8226837c56ae | 86 | static char subscription_url[MQTT_MAX_PAYLOAD_SIZE]; |
DuyLionTran | 32:8226837c56ae | 87 | |
DuyLionTran | 32:8226837c56ae | 88 | extern struct UploadValue DataStruct; |
DuyLionTran | 32:8226837c56ae | 89 | /*************************************************************** |
DuyLionTran | 32:8226837c56ae | 90 | * Unity function definitions |
DuyLionTran | 32:8226837c56ae | 91 | ***************************************************************/ |
DuyLionTran | 32:8226837c56ae | 92 | void MQTT_MessageHandles(uint8_t ControlSignal); |
DuyLionTran | 32:8226837c56ae | 93 | |
DuyLionTran | 32:8226837c56ae | 94 | /** brief Callback function when MQTT message arrives |
DuyLionTran | 32:8226837c56ae | 95 | * param[in] msgMQTT |
DuyLionTran | 32:8226837c56ae | 96 | * retral None |
DuyLionTran | 32:8226837c56ae | 97 | */ |
DuyLionTran | 32:8226837c56ae | 98 | void MQTT_SubscribeCallback(MQTT::MessageData &msgMQTT); |
DuyLionTran | 32:8226837c56ae | 99 | |
DuyLionTran | 32:8226837c56ae | 100 | /** brief Subscribe to a MQTT topic and set the MQTT callback function |
DuyLionTran | 32:8226837c56ae | 101 | * param[in] subscribeTopic Topic to be subscribed |
DuyLionTran | 32:8226837c56ae | 102 | * param[in] client MQTT client |
DuyLionTran | 32:8226837c56ae | 103 | * retral returnCode from MQTTClient.h |
DuyLionTran | 32:8226837c56ae | 104 | */ |
DuyLionTran | 32:8226837c56ae | 105 | int MQTT_Subscribe(char *subscribeTopic, MQTT::Client<MQTTNetwork, Countdown, MQTT_MAX_PACKET_SIZE>* client, struct UploadValue uploadStruct); |
DuyLionTran | 32:8226837c56ae | 106 | |
DuyLionTran | 32:8226837c56ae | 107 | /** brief Connect to the internet then the MQTT network |
DuyLionTran | 32:8226837c56ae | 108 | * param[in] client MQTT client |
DuyLionTran | 32:8226837c56ae | 109 | * param[in] mqttNetwork MQTT network |
DuyLionTran | 32:8226837c56ae | 110 | * param[in] network The internet network interface (ethernet, wifi...) |
DuyLionTran | 32:8226837c56ae | 111 | * retral Internet connect result and returnCode from MQTTClient.h |
DuyLionTran | 32:8226837c56ae | 112 | */ |
DuyLionTran | 32:8226837c56ae | 113 | int MQTT_Connect(MQTT::Client<MQTTNetwork, Countdown, MQTT_MAX_PACKET_SIZE>* client, MQTTNetwork *mqttNetwork, NetworkInterface* network, struct UploadValue uploadStruct); |
DuyLionTran | 32:8226837c56ae | 114 | |
DuyLionTran | 32:8226837c56ae | 115 | /** brief Setup the number of attempt to re-connect to the internet |
DuyLionTran | 32:8226837c56ae | 116 | * param[in] attemptNumber The number of attemp |
DuyLionTran | 32:8226837c56ae | 117 | */ |
DuyLionTran | 32:8226837c56ae | 118 | int MQTT_GetConnTimeout(int attemptNumber); |
DuyLionTran | 32:8226837c56ae | 119 | |
DuyLionTran | 32:8226837c56ae | 120 | /** brief Try to reconnect to the internet and MQTT network |
DuyLionTran | 32:8226837c56ae | 121 | * retral None |
DuyLionTran | 32:8226837c56ae | 122 | */ |
DuyLionTran | 32:8226837c56ae | 123 | void MQTT_AttemptConnect(MQTT::Client<MQTTNetwork, Countdown, MQTT_MAX_PACKET_SIZE>* client, MQTTNetwork *mqttNetwork, NetworkInterface* network, struct UploadValue uploadStruct); |
DuyLionTran | 32:8226837c56ae | 124 | |
DuyLionTran | 32:8226837c56ae | 125 | /** brief Publish ADC values to the server |
DuyLionTran | 32:8226837c56ae | 126 | * param[in] client MQTT client |
DuyLionTran | 32:8226837c56ae | 127 | * param[in] inputTime The time when the data is attempt to be sent |
DuyLionTran | 32:8226837c56ae | 128 | * param[in] adcVal_0 The ADC value to be sent |
DuyLionTran | 32:8226837c56ae | 129 | * retral returnCode from MQTTClient.h |
DuyLionTran | 32:8226837c56ae | 130 | */ |
DuyLionTran | 32:8226837c56ae | 131 | int MQTT_PublishADC(MQTT::Client<MQTTNetwork, Countdown, MQTT_MAX_PACKET_SIZE>* client, time_t inputTime, float adcVal_0); |
DuyLionTran | 32:8226837c56ae | 132 | |
DuyLionTran | 32:8226837c56ae | 133 | /** brief Publish Sensor values to the server |
DuyLionTran | 32:8226837c56ae | 134 | * param[in] client MQTT client |
DuyLionTran | 32:8226837c56ae | 135 | * param[in] inputTime The time when the data is attempt to be sent |
DuyLionTran | 32:8226837c56ae | 136 | * param[in] pHVal The pHVal value to be sent |
DuyLionTran | 32:8226837c56ae | 137 | * retral returnCode from MQTTClient.h |
DuyLionTran | 32:8226837c56ae | 138 | */ |
DuyLionTran | 43:dcde0e66874a | 139 | int MQTT_PublishSensorVal(MQTT::Client<MQTTNetwork, Countdown, MQTT_MAX_PACKET_SIZE>* client, time_t inputTime, float TempVal, float DOVal); |
DuyLionTran | 32:8226837c56ae | 140 | |
DuyLionTran | 32:8226837c56ae | 141 | /** brief Publish relay states to the server |
DuyLionTran | 32:8226837c56ae | 142 | * param[in] client MQTT client |
DuyLionTran | 32:8226837c56ae | 143 | * param[in] inputTime The time when the data is attempt to be sent |
DuyLionTran | 32:8226837c56ae | 144 | * param[in] relay1 Relay 1 state |
DuyLionTran | 32:8226837c56ae | 145 | * param[in] relay2 Relay 2 state |
DuyLionTran | 32:8226837c56ae | 146 | * retral returnCode from MQTTClient.h |
DuyLionTran | 32:8226837c56ae | 147 | */ |
DuyLionTran | 36:d0b628087ac8 | 148 | int MQTT_PublishRelayState(MQTT::Client<MQTTNetwork, Countdown, MQTT_MAX_PACKET_SIZE>* client, time_t inputTime, int relay1, int relay2, int relay3); |
DuyLionTran | 32:8226837c56ae | 149 | |
DuyLionTran | 32:8226837c56ae | 150 | /** brief Publish relay states to the server |
DuyLionTran | 32:8226837c56ae | 151 | * param[in] client MQTT client |
DuyLionTran | 32:8226837c56ae | 152 | * param[in] inputTime The time when the data is attempt to be sent |
DuyLionTran | 32:8226837c56ae | 153 | * param[in] mode current mode: automatic (0) or manual (1) |
DuyLionTran | 32:8226837c56ae | 154 | * param[in] maxOxi Maximum Oxygen value |
DuyLionTran | 32:8226837c56ae | 155 | * param[in] minOxi Minimum Oxygen value |
DuyLionTran | 32:8226837c56ae | 156 | // * param[in] uploadInterval Interval between upload turns |
DuyLionTran | 32:8226837c56ae | 157 | * retral returnCode from MQTTClient.h |
DuyLionTran | 32:8226837c56ae | 158 | */ |
DuyLionTran | 43:dcde0e66874a | 159 | int MQTT_PublishConfigValue(MQTT::Client<MQTTNetwork, Countdown, MQTT_MAX_PACKET_SIZE>* client, time_t inputTime, uint8_t mode, uint8_t OxyThreshold, uint8_t TemperatureThreshold, uint16_t UploadInterval); |
DuyLionTran | 32:8226837c56ae | 160 | |
DuyLionTran | 32:8226837c56ae | 161 | /** brief Upload all the data to the MQTT server |
DuyLionTran | 32:8226837c56ae | 162 | * param[in] client MQTT client |
DuyLionTran | 32:8226837c56ae | 163 | * param[in] inputTime The time when the data is attempt to be sent |
DuyLionTran | 32:8226837c56ae | 164 | * param[in] uploadInterval The period between each upload moment |
DuyLionTran | 32:8226837c56ae | 165 | * retral returnCode from MQTTClient.h |
DuyLionTran | 32:8226837c56ae | 166 | */ |
DuyLionTran | 32:8226837c56ae | 167 | int MQTT_PublishAll(MQTT::Client<MQTTNetwork, Countdown, MQTT_MAX_PACKET_SIZE>* client, time_t inputTime, uint8_t uploadType, struct UploadValue uploadStruct); |
DuyLionTran | 32:8226837c56ae | 168 | |
DuyLionTran | 32:8226837c56ae | 169 | /********************************************************************************************************************************************************************************************/ |
DuyLionTran | 32:8226837c56ae | 170 | /*************************************************************** |
DuyLionTran | 32:8226837c56ae | 171 | * Unity function declarations |
DuyLionTran | 32:8226837c56ae | 172 | ***************************************************************/ |
DuyLionTran | 32:8226837c56ae | 173 | void MQTT_SubscribeCallback(MQTT::MessageData &msgMQTT) { |
DuyLionTran | 32:8226837c56ae | 174 | // Message Handles |
DuyLionTran | 32:8226837c56ae | 175 | char msg[MQTT_MAX_PAYLOAD_SIZE]; |
DuyLionTran | 32:8226837c56ae | 176 | msg[0]='\0'; |
DuyLionTran | 32:8226837c56ae | 177 | strncat (msg, (char*)msgMQTT.message.payload, msgMQTT.message.payloadlen); |
DuyLionTran | 32:8226837c56ae | 178 | printf ("--->>> MQTT_SubscribeCallback msg: %s\n\r", msg); |
DuyLionTran | 39:a5ee98bd0050 | 179 | /* {"type":"3","deviceId":"string"} */ |
DuyLionTran | 32:8226837c56ae | 180 | Json json(msg, msgMQTT.message.payloadlen); |
DuyLionTran | 32:8226837c56ae | 181 | if (!json.isValidJson()) { |
DuyLionTran | 32:8226837c56ae | 182 | printf("Invalid JSON: %s", msg); |
DuyLionTran | 32:8226837c56ae | 183 | } |
DuyLionTran | 32:8226837c56ae | 184 | else { |
DuyLionTran | 32:8226837c56ae | 185 | if (json.type(0) != JSMN_OBJECT ) { |
DuyLionTran | 32:8226837c56ae | 186 | printf("Invalid JSON. ROOT element is not Object: %s", msg); |
DuyLionTran | 32:8226837c56ae | 187 | } |
DuyLionTran | 32:8226837c56ae | 188 | else { |
DuyLionTran | 32:8226837c56ae | 189 | int CommandType; |
DuyLionTran | 32:8226837c56ae | 190 | int KeyIndex = json.findKeyIndexIn("type", 0); |
DuyLionTran | 32:8226837c56ae | 191 | int KeyValueIndex = json.findChildIndexOf(KeyIndex, 0); |
DuyLionTran | 32:8226837c56ae | 192 | int ret = json.tokenIntegerValue(KeyValueIndex, CommandType); |
DuyLionTran | 32:8226837c56ae | 193 | |
DuyLionTran | 32:8226837c56ae | 194 | int receiveCmdID; |
DuyLionTran | 32:8226837c56ae | 195 | printf("Command Type: %d, error %d\r\n", CommandType, ret); |
DuyLionTran | 32:8226837c56ae | 196 | |
DuyLionTran | 32:8226837c56ae | 197 | switch (CommandType) { |
DuyLionTran | 45:92da959d624b | 198 | case 0: printf("Calibrate\r\n"); |
DuyLionTran | 45:92da959d624b | 199 | CE_Calibrate(); |
DuyLionTran | 39:a5ee98bd0050 | 200 | break; |
DuyLionTran | 39:a5ee98bd0050 | 201 | |
DuyLionTran | 45:92da959d624b | 202 | case 1: printf("Set relay alarm state\r\n"); |
DuyLionTran | 50:5a19fc4b41d9 | 203 | int AlarmTime, SetRelayState1, SetRelayState2; |
DuyLionTran | 50:5a19fc4b41d9 | 204 | KeyIndex = json.findKeyIndexIn("cmdID", 0); |
DuyLionTran | 50:5a19fc4b41d9 | 205 | KeyValueIndex = json.findChildIndexOf(KeyIndex, 0); |
DuyLionTran | 50:5a19fc4b41d9 | 206 | ret = json.tokenIntegerValue(KeyValueIndex, receiveCmdID); |
DuyLionTran | 50:5a19fc4b41d9 | 207 | |
DuyLionTran | 50:5a19fc4b41d9 | 208 | KeyIndex = json.findKeyIndexIn("AlarmTime", 0); |
DuyLionTran | 50:5a19fc4b41d9 | 209 | KeyValueIndex = json.findChildIndexOf(KeyIndex, 0); |
DuyLionTran | 50:5a19fc4b41d9 | 210 | ret = json.tokenIntegerValue(KeyValueIndex, AlarmTime); |
DuyLionTran | 50:5a19fc4b41d9 | 211 | |
DuyLionTran | 50:5a19fc4b41d9 | 212 | KeyIndex = json.findKeyIndexIn("SetRelayState1", 0); |
DuyLionTran | 50:5a19fc4b41d9 | 213 | KeyValueIndex = json.findChildIndexOf(KeyIndex, 0); |
DuyLionTran | 50:5a19fc4b41d9 | 214 | ret = json.tokenIntegerValue(KeyValueIndex, SetRelayState1); |
DuyLionTran | 50:5a19fc4b41d9 | 215 | |
DuyLionTran | 50:5a19fc4b41d9 | 216 | KeyIndex = json.findKeyIndexIn("SetRelayState2", 0); |
DuyLionTran | 50:5a19fc4b41d9 | 217 | KeyValueIndex = json.findChildIndexOf(KeyIndex, 0); |
DuyLionTran | 50:5a19fc4b41d9 | 218 | ret = json.tokenIntegerValue(KeyValueIndex, SetRelayState2); |
DuyLionTran | 50:5a19fc4b41d9 | 219 | |
DuyLionTran | 50:5a19fc4b41d9 | 220 | DataStruct.CONFIG_AlarmTime = AlarmTime; |
DuyLionTran | 50:5a19fc4b41d9 | 221 | DataStruct.CONFIG_SetRelayState_1 = SetRelayState1; |
DuyLionTran | 50:5a19fc4b41d9 | 222 | DataStruct.CONFIG_SetRelayState_2 = SetRelayState2; |
DuyLionTran | 50:5a19fc4b41d9 | 223 | FP_SetAlarmValues(DataStruct.CONFIG_AlarmTime, DataStruct.CONFIG_SetRelayState_1, DataStruct.CONFIG_SetRelayState_2); |
DuyLionTran | 45:92da959d624b | 224 | break; |
DuyLionTran | 43:dcde0e66874a | 225 | |
DuyLionTran | 45:92da959d624b | 226 | case 2: printf("Set relay state\r\n"); |
DuyLionTran | 45:92da959d624b | 227 | int relayState1, relayState2, relayState3; |
DuyLionTran | 32:8226837c56ae | 228 | KeyIndex = json.findKeyIndexIn("cmdID", 0); |
DuyLionTran | 32:8226837c56ae | 229 | KeyValueIndex = json.findChildIndexOf(KeyIndex, 0); |
DuyLionTran | 32:8226837c56ae | 230 | ret = json.tokenIntegerValue(KeyValueIndex, receiveCmdID); |
DuyLionTran | 32:8226837c56ae | 231 | |
DuyLionTran | 32:8226837c56ae | 232 | KeyIndex = json.findKeyIndexIn("relayState1", 0); |
DuyLionTran | 32:8226837c56ae | 233 | KeyValueIndex = json.findChildIndexOf(KeyIndex, 0); |
DuyLionTran | 33:5b90257d2d57 | 234 | ret = json.tokenIntegerValue(KeyValueIndex, relayState1); |
DuyLionTran | 32:8226837c56ae | 235 | |
DuyLionTran | 33:5b90257d2d57 | 236 | KeyIndex = json.findKeyIndexIn("relayState2", 0); |
DuyLionTran | 33:5b90257d2d57 | 237 | KeyValueIndex = json.findChildIndexOf(KeyIndex, 0); |
DuyLionTran | 33:5b90257d2d57 | 238 | ret = json.tokenIntegerValue(KeyValueIndex, relayState2); |
DuyLionTran | 33:5b90257d2d57 | 239 | |
DuyLionTran | 34:601effb7b7fe | 240 | KeyIndex = json.findKeyIndexIn("relayState3", 0); |
DuyLionTran | 34:601effb7b7fe | 241 | KeyValueIndex = json.findChildIndexOf(KeyIndex, 0); |
DuyLionTran | 34:601effb7b7fe | 242 | ret = json.tokenIntegerValue(KeyValueIndex, relayState3); |
DuyLionTran | 34:601effb7b7fe | 243 | |
DuyLionTran | 50:5a19fc4b41d9 | 244 | if (DataStruct.CONFIG_Mode == 1) { |
DuyLionTran | 50:5a19fc4b41d9 | 245 | DataStruct.RELAY_State_1 = relayState1; |
DuyLionTran | 50:5a19fc4b41d9 | 246 | DataStruct.RELAY_State_2 = relayState2; |
DuyLionTran | 50:5a19fc4b41d9 | 247 | DataStruct.RELAY_State_3 = relayState3; |
DuyLionTran | 50:5a19fc4b41d9 | 248 | FP_WriteRelayStates(DataStruct.RELAY_State_1, DataStruct.RELAY_State_2, DataStruct.RELAY_State_3); |
DuyLionTran | 50:5a19fc4b41d9 | 249 | CE_HandleRelays(relayState1, relayState2, relayState3); |
DuyLionTran | 50:5a19fc4b41d9 | 250 | } |
DuyLionTran | 50:5a19fc4b41d9 | 251 | |
DuyLionTran | 32:8226837c56ae | 252 | break; |
DuyLionTran | 32:8226837c56ae | 253 | |
DuyLionTran | 45:92da959d624b | 254 | case 3: printf("Set config values\r\n"); |
DuyLionTran | 45:92da959d624b | 255 | int mode, OxiThres, TempThres, uploadInterval, setRTCTime; |
DuyLionTran | 32:8226837c56ae | 256 | KeyIndex = json.findKeyIndexIn("cmdID", 0); |
DuyLionTran | 32:8226837c56ae | 257 | KeyValueIndex = json.findChildIndexOf(KeyIndex, 0); |
DuyLionTran | 32:8226837c56ae | 258 | ret = json.tokenIntegerValue(KeyValueIndex, receiveCmdID); |
DuyLionTran | 32:8226837c56ae | 259 | |
DuyLionTran | 32:8226837c56ae | 260 | KeyIndex = json.findKeyIndexIn("mode", 0); |
DuyLionTran | 32:8226837c56ae | 261 | KeyValueIndex = json.findChildIndexOf(KeyIndex, 0); |
DuyLionTran | 32:8226837c56ae | 262 | ret = json.tokenIntegerValue(KeyValueIndex, mode); |
DuyLionTran | 32:8226837c56ae | 263 | |
DuyLionTran | 43:dcde0e66874a | 264 | KeyIndex = json.findKeyIndexIn("OxygenThreshold", 0); |
DuyLionTran | 32:8226837c56ae | 265 | KeyValueIndex = json.findChildIndexOf(KeyIndex, 0); |
DuyLionTran | 43:dcde0e66874a | 266 | ret = json.tokenIntegerValue(KeyValueIndex, OxiThres); |
DuyLionTran | 32:8226837c56ae | 267 | |
DuyLionTran | 43:dcde0e66874a | 268 | KeyIndex = json.findKeyIndexIn("TemperatureThreshold", 0); |
DuyLionTran | 32:8226837c56ae | 269 | KeyValueIndex = json.findChildIndexOf(KeyIndex, 0); |
DuyLionTran | 43:dcde0e66874a | 270 | ret = json.tokenIntegerValue(KeyValueIndex, TempThres); |
DuyLionTran | 33:5b90257d2d57 | 271 | |
DuyLionTran | 33:5b90257d2d57 | 272 | KeyIndex = json.findKeyIndexIn("uploadInterval", 0); |
DuyLionTran | 33:5b90257d2d57 | 273 | KeyValueIndex = json.findChildIndexOf(KeyIndex, 0); |
DuyLionTran | 35:fc800d35c1ba | 274 | ret = json.tokenIntegerValue(KeyValueIndex, uploadInterval); |
DuyLionTran | 35:fc800d35c1ba | 275 | |
DuyLionTran | 35:fc800d35c1ba | 276 | KeyIndex = json.findKeyIndexIn("setRTCTime", 0); |
DuyLionTran | 35:fc800d35c1ba | 277 | KeyValueIndex = json.findChildIndexOf(KeyIndex, 0); |
DuyLionTran | 35:fc800d35c1ba | 278 | ret = json.tokenIntegerValue(KeyValueIndex, setRTCTime); |
DuyLionTran | 32:8226837c56ae | 279 | |
DuyLionTran | 43:dcde0e66874a | 280 | DataStruct.CONFIG_Mode = mode; |
DuyLionTran | 43:dcde0e66874a | 281 | DataStruct.CONFIG_OxyThreshold = OxiThres; |
DuyLionTran | 43:dcde0e66874a | 282 | DataStruct.CONFIG_TemperatureThreshold = TempThres; |
DuyLionTran | 43:dcde0e66874a | 283 | DataStruct.CONFIG_UploadInterval = uploadInterval; |
DuyLionTran | 43:dcde0e66874a | 284 | FP_WriteConfigValues(DataStruct.CONFIG_Mode, DataStruct.CONFIG_OxyThreshold, DataStruct.CONFIG_TemperatureThreshold, DataStruct.CONFIG_UploadInterval); |
DuyLionTran | 35:fc800d35c1ba | 285 | CE_SetRTCTime(setRTCTime); |
DuyLionTran | 32:8226837c56ae | 286 | break; |
DuyLionTran | 32:8226837c56ae | 287 | |
DuyLionTran | 45:92da959d624b | 288 | case 4: printf("Synchronize data\r\n"); |
DuyLionTran | 45:92da959d624b | 289 | CE_UpdateImmediately(); |
DuyLionTran | 43:dcde0e66874a | 290 | break; |
DuyLionTran | 43:dcde0e66874a | 291 | |
DuyLionTran | 32:8226837c56ae | 292 | default: break; |
DuyLionTran | 32:8226837c56ae | 293 | } |
DuyLionTran | 32:8226837c56ae | 294 | } |
DuyLionTran | 32:8226837c56ae | 295 | } |
DuyLionTran | 32:8226837c56ae | 296 | } |
DuyLionTran | 32:8226837c56ae | 297 | |
DuyLionTran | 32:8226837c56ae | 298 | int MQTT_Subscribe(char *subscribeTopic, MQTT::Client<MQTTNetwork, Countdown, MQTT_MAX_PACKET_SIZE>* client, struct UploadValue uploadStruct) { |
DuyLionTran | 32:8226837c56ae | 299 | return client->subscribe(subscribeTopic, MQTT::QOS1, MQTT_SubscribeCallback); |
DuyLionTran | 32:8226837c56ae | 300 | } |
DuyLionTran | 32:8226837c56ae | 301 | |
DuyLionTran | 32:8226837c56ae | 302 | int MQTT_Connect(MQTT::Client<MQTTNetwork, Countdown, MQTT_MAX_PACKET_SIZE>* client, MQTTNetwork *mqttNetwork, NetworkInterface* network, struct UploadValue uploadStruct) { |
DuyLionTran | 32:8226837c56ae | 303 | const char* iot_ibm = MQTT_BROKER_URL; |
DuyLionTran | 32:8226837c56ae | 304 | char hostname[strlen(org) + strlen(iot_ibm) + 1]; |
DuyLionTran | 32:8226837c56ae | 305 | |
DuyLionTran | 32:8226837c56ae | 306 | sprintf(hostname, "%s%s", org, iot_ibm); |
DuyLionTran | 32:8226837c56ae | 307 | // Construct clientId - d:org:type:id |
DuyLionTran | 32:8226837c56ae | 308 | char clientId[strlen(org) + strlen(type) + strlen(id) + 5]; |
DuyLionTran | 32:8226837c56ae | 309 | sprintf(clientId, "d:%s:%s:%s", org, type, id); |
DuyLionTran | 32:8226837c56ae | 310 | sprintf(subscription_url, "%s.%s/#/device/%s/%s/", org, "internetofthings.ibmcloud.com", id, DEFAULT_TYPE_NAME); |
DuyLionTran | 32:8226837c56ae | 311 | |
DuyLionTran | 32:8226837c56ae | 312 | // Network debug statements |
DuyLionTran | 32:8226837c56ae | 313 | LOG("=====================================\n\r"); |
DuyLionTran | 32:8226837c56ae | 314 | LOG("Nucleo IP ADDRESS: %s\n\r", network->get_ip_address()); |
DuyLionTran | 32:8226837c56ae | 315 | LOG("Nucleo MAC ADDRESS: %s\n\r", network->get_mac_address()); |
DuyLionTran | 32:8226837c56ae | 316 | LOG("Server Hostname: %s port: %d\n\r", hostname, IBM_IOT_PORT); |
DuyLionTran | 32:8226837c56ae | 317 | LOG("Client ID: %s\n\r", clientId); |
DuyLionTran | 32:8226837c56ae | 318 | LOG("Topic: %s\n\r",MQTT_EVENT_TOPIC); |
DuyLionTran | 32:8226837c56ae | 319 | LOG("Subscription URL: %s\n\r", subscription_url); |
DuyLionTran | 32:8226837c56ae | 320 | LOG("=====================================\n\r"); |
DuyLionTran | 32:8226837c56ae | 321 | netConnecting = true; |
DuyLionTran | 32:8226837c56ae | 322 | int rc = mqttNetwork->connect(hostname, IBM_IOT_PORT); |
DuyLionTran | 32:8226837c56ae | 323 | if (rc != 0) { |
DuyLionTran | 32:8226837c56ae | 324 | printf("rc from TCP connect is %d\r\n", rc); |
DuyLionTran | 32:8226837c56ae | 325 | return rc; |
DuyLionTran | 32:8226837c56ae | 326 | } |
DuyLionTran | 32:8226837c56ae | 327 | |
DuyLionTran | 32:8226837c56ae | 328 | printf ("--->TCP Connected\n\r"); |
DuyLionTran | 32:8226837c56ae | 329 | netConnected = true; |
DuyLionTran | 32:8226837c56ae | 330 | netConnecting = false; |
DuyLionTran | 32:8226837c56ae | 331 | |
DuyLionTran | 32:8226837c56ae | 332 | // MQTT Connect |
DuyLionTran | 32:8226837c56ae | 333 | mqttConnecting = true; |
DuyLionTran | 32:8226837c56ae | 334 | MQTTPacket_connectData data = MQTTPacket_connectData_initializer; |
DuyLionTran | 32:8226837c56ae | 335 | data.MQTTVersion = 4; |
DuyLionTran | 32:8226837c56ae | 336 | data.struct_version = 0; |
DuyLionTran | 32:8226837c56ae | 337 | data.clientID.cstring = clientId; |
DuyLionTran | 32:8226837c56ae | 338 | data.keepAliveInterval = MQTT_KEEPALIVE; // in Sec |
DuyLionTran | 32:8226837c56ae | 339 | data.username.cstring = AUTH_METHOD; |
DuyLionTran | 32:8226837c56ae | 340 | data.password.cstring = auth_token; |
DuyLionTran | 32:8226837c56ae | 341 | printf ("AutToken: %s\n\r", auth_token); |
DuyLionTran | 32:8226837c56ae | 342 | |
DuyLionTran | 32:8226837c56ae | 343 | if ((rc = client->connect(data)) != 0) { |
DuyLionTran | 32:8226837c56ae | 344 | printf("rc from MQTT connect is %d\r\n", rc); |
DuyLionTran | 32:8226837c56ae | 345 | connack_rc = rc; |
DuyLionTran | 32:8226837c56ae | 346 | return rc; |
DuyLionTran | 32:8226837c56ae | 347 | } |
DuyLionTran | 32:8226837c56ae | 348 | connected = true; |
DuyLionTran | 32:8226837c56ae | 349 | printf ("--->MQTT Connected\n\r"); |
DuyLionTran | 32:8226837c56ae | 350 | if ((rc = MQTT_Subscribe(MQTT_COMMAND_TOPIC, client, uploadStruct)) == 0) { |
DuyLionTran | 32:8226837c56ae | 351 | LOG ("--->>>MQTT subscribed to: %s\n\r", MQTT_COMMAND_TOPIC); |
DuyLionTran | 32:8226837c56ae | 352 | } else { |
DuyLionTran | 32:8226837c56ae | 353 | LOG ("--->>>ERROR MQTT subscribe : %s\n\r", MQTT_COMMAND_TOPIC); |
DuyLionTran | 32:8226837c56ae | 354 | } |
DuyLionTran | 32:8226837c56ae | 355 | mqttConnecting = false; |
DuyLionTran | 32:8226837c56ae | 356 | connack_rc = rc; |
DuyLionTran | 32:8226837c56ae | 357 | return rc; |
DuyLionTran | 32:8226837c56ae | 358 | } |
DuyLionTran | 32:8226837c56ae | 359 | |
DuyLionTran | 32:8226837c56ae | 360 | |
DuyLionTran | 32:8226837c56ae | 361 | int MQTT_GetConnTimeout(int attemptNumber) { // First 10 attempts try within 3 seconds, next 10 attempts retry after every 1 minute |
DuyLionTran | 32:8226837c56ae | 362 | // after 20 attempts, retry every 10 minutes |
DuyLionTran | 32:8226837c56ae | 363 | return (attemptNumber < 10) ? 3 : (attemptNumber < 20) ? 60 : 600; |
DuyLionTran | 32:8226837c56ae | 364 | } |
DuyLionTran | 32:8226837c56ae | 365 | |
DuyLionTran | 32:8226837c56ae | 366 | |
DuyLionTran | 32:8226837c56ae | 367 | void MQTT_AttemptConnect(MQTT::Client<MQTTNetwork, Countdown, MQTT_MAX_PACKET_SIZE>* client, MQTTNetwork *mqttNetwork, NetworkInterface* network, struct UploadValue uploadStruct) { |
DuyLionTran | 32:8226837c56ae | 368 | connected = false; |
DuyLionTran | 32:8226837c56ae | 369 | |
DuyLionTran | 32:8226837c56ae | 370 | while (MQTT_Connect(client, mqttNetwork, network, uploadStruct) != MQTT_CONNECTION_ACCEPTED) { |
DuyLionTran | 32:8226837c56ae | 371 | if (connack_rc == MQTT_NOT_AUTHORIZED || connack_rc == MQTT_BAD_USERNAME_OR_PASSWORD) { |
DuyLionTran | 32:8226837c56ae | 372 | printf ("File: %s, Line: %d Error: %d\n\r",__FILE__,__LINE__, connack_rc); |
DuyLionTran | 32:8226837c56ae | 373 | return; // don't reattempt to connect if credentials are wrong |
DuyLionTran | 32:8226837c56ae | 374 | } |
DuyLionTran | 32:8226837c56ae | 375 | int timeout = MQTT_GetConnTimeout(++retryAttempt); |
DuyLionTran | 32:8226837c56ae | 376 | WARN("Retry attempt number %d waiting %d\n", retryAttempt, timeout); |
DuyLionTran | 32:8226837c56ae | 377 | |
DuyLionTran | 32:8226837c56ae | 378 | // if ipstack and client were on the heap we could deconstruct and goto a label where they are constructed |
DuyLionTran | 32:8226837c56ae | 379 | // or maybe just add the proper members to do this disconnect and call MQTT_AttemptConnect(...) |
DuyLionTran | 32:8226837c56ae | 380 | // this works - reset the system when the retry count gets to a threshold |
DuyLionTran | 32:8226837c56ae | 381 | if (retryAttempt == 5) |
DuyLionTran | 32:8226837c56ae | 382 | NVIC_SystemReset(); |
DuyLionTran | 32:8226837c56ae | 383 | else |
DuyLionTran | 32:8226837c56ae | 384 | wait(timeout); |
DuyLionTran | 32:8226837c56ae | 385 | } |
DuyLionTran | 32:8226837c56ae | 386 | } |
DuyLionTran | 32:8226837c56ae | 387 | |
DuyLionTran | 32:8226837c56ae | 388 | int MQTT_PublishADC(MQTT::Client<MQTTNetwork, Countdown, MQTT_MAX_PACKET_SIZE>* client, time_t inputTime, float adcVal_0) { |
DuyLionTran | 32:8226837c56ae | 389 | MQTT::Message message; |
DuyLionTran | 32:8226837c56ae | 390 | const char* pubTopic = MQTT_EVENT_TOPIC; |
DuyLionTran | 32:8226837c56ae | 391 | |
DuyLionTran | 32:8226837c56ae | 392 | char buf[MQTT_MAX_PAYLOAD_SIZE]; |
DuyLionTran | 32:8226837c56ae | 393 | char timeBuf[50]; |
DuyLionTran | 32:8226837c56ae | 394 | |
DuyLionTran | 32:8226837c56ae | 395 | if (!client->isConnected()) { |
DuyLionTran | 32:8226837c56ae | 396 | printf ("---> MQTT DISCONNECTED\n\r"); return MQTT::FAILURE; |
DuyLionTran | 32:8226837c56ae | 397 | } |
DuyLionTran | 32:8226837c56ae | 398 | |
DuyLionTran | 32:8226837c56ae | 399 | strftime(timeBuf, 50, "%Y/%m/%d %H:%M:%S", localtime(&inputTime)); |
DuyLionTran | 32:8226837c56ae | 400 | sprintf(buf, "{\"type\":1,\"deviceId\":\"PROEVN\",\"time\":\"%s\",\"cmdId\":%d,\"adc0\":%.1f}", |
DuyLionTran | 32:8226837c56ae | 401 | timeBuf, commandID, adcVal_0); |
DuyLionTran | 32:8226837c56ae | 402 | message.qos = MQTT::QOS0; |
DuyLionTran | 32:8226837c56ae | 403 | message.retained = false; |
DuyLionTran | 32:8226837c56ae | 404 | message.dup = false; |
DuyLionTran | 32:8226837c56ae | 405 | message.payload = (void*)buf; |
DuyLionTran | 32:8226837c56ae | 406 | message.payloadlen = strlen(buf); |
DuyLionTran | 32:8226837c56ae | 407 | |
DuyLionTran | 32:8226837c56ae | 408 | if((message.payloadlen + strlen(pubTopic)+1) >= MQTT_MAX_PACKET_SIZE) |
DuyLionTran | 32:8226837c56ae | 409 | printf("message too long!\r\n"); |
DuyLionTran | 32:8226837c56ae | 410 | |
DuyLionTran | 32:8226837c56ae | 411 | LOG("Publishing %s\n\r", buf); |
DuyLionTran | 32:8226837c56ae | 412 | return client->publish(pubTopic, message); |
DuyLionTran | 32:8226837c56ae | 413 | } |
DuyLionTran | 32:8226837c56ae | 414 | |
DuyLionTran | 43:dcde0e66874a | 415 | int MQTT_PublishSensorVal(MQTT::Client<MQTTNetwork, Countdown, MQTT_MAX_PACKET_SIZE>* client, time_t inputTime, float TempVal, float DOVal) { |
DuyLionTran | 32:8226837c56ae | 416 | MQTT::Message message; |
DuyLionTran | 32:8226837c56ae | 417 | const char* pubTopic = MQTT_EVENT_TOPIC; |
DuyLionTran | 32:8226837c56ae | 418 | |
DuyLionTran | 32:8226837c56ae | 419 | char buf[MQTT_MAX_PAYLOAD_SIZE]; |
DuyLionTran | 47:c3707a4f69a7 | 420 | // char timeBuf[50]; |
DuyLionTran | 32:8226837c56ae | 421 | |
DuyLionTran | 32:8226837c56ae | 422 | if (!client->isConnected()) { |
DuyLionTran | 32:8226837c56ae | 423 | printf ("---> MQTT DISCONNECTED\n\r"); return MQTT::FAILURE; |
DuyLionTran | 32:8226837c56ae | 424 | } |
DuyLionTran | 32:8226837c56ae | 425 | |
DuyLionTran | 47:c3707a4f69a7 | 426 | // strftime(timeBuf, 50, "%Y/%m/%d %H:%M:%S", localtime(&inputTime)); |
DuyLionTran | 48:a7ed665844cd | 427 | sprintf(buf, "{\"type\":2,\"deviceId\":\"PROEVN\",\"time\":%d,\"cmdId\":%d,\"temperature0\":%.2f,\"oxygen0\":%.2f}", |
DuyLionTran | 47:c3707a4f69a7 | 428 | inputTime, commandID, TempVal ,DOVal); |
DuyLionTran | 32:8226837c56ae | 429 | message.qos = MQTT::QOS0; |
DuyLionTran | 32:8226837c56ae | 430 | message.retained = false; |
DuyLionTran | 32:8226837c56ae | 431 | message.dup = false; |
DuyLionTran | 32:8226837c56ae | 432 | message.payload = (void*)buf; |
DuyLionTran | 32:8226837c56ae | 433 | message.payloadlen = strlen(buf); |
DuyLionTran | 32:8226837c56ae | 434 | |
DuyLionTran | 32:8226837c56ae | 435 | if((message.payloadlen + strlen(pubTopic)+1) >= MQTT_MAX_PACKET_SIZE) |
DuyLionTran | 32:8226837c56ae | 436 | printf("message too long!\r\n"); |
DuyLionTran | 32:8226837c56ae | 437 | |
DuyLionTran | 32:8226837c56ae | 438 | LOG("Publishing %s\n\r", buf); |
DuyLionTran | 32:8226837c56ae | 439 | return client->publish(pubTopic, message); |
DuyLionTran | 32:8226837c56ae | 440 | } |
DuyLionTran | 32:8226837c56ae | 441 | |
DuyLionTran | 36:d0b628087ac8 | 442 | int MQTT_PublishRelayState(MQTT::Client<MQTTNetwork, Countdown, MQTT_MAX_PACKET_SIZE>* client, time_t inputTime, int relay1, int relay2, int relay3) { |
DuyLionTran | 32:8226837c56ae | 443 | MQTT::Message message; |
DuyLionTran | 32:8226837c56ae | 444 | const char* pubTopic = MQTT_EVENT_TOPIC; |
DuyLionTran | 32:8226837c56ae | 445 | char buf[MQTT_MAX_PAYLOAD_SIZE]; |
DuyLionTran | 47:c3707a4f69a7 | 446 | // char timeBuf[50]; |
DuyLionTran | 32:8226837c56ae | 447 | |
DuyLionTran | 32:8226837c56ae | 448 | if (!client->isConnected()) { |
DuyLionTran | 32:8226837c56ae | 449 | printf ("---> MQTT DISCONNECTED\n\r"); |
DuyLionTran | 32:8226837c56ae | 450 | return MQTT::FAILURE; |
DuyLionTran | 32:8226837c56ae | 451 | } |
DuyLionTran | 47:c3707a4f69a7 | 452 | // strftime(timeBuf, 50, "%Y/%m/%d %H:%M:%S", localtime(&inputTime)); |
DuyLionTran | 48:a7ed665844cd | 453 | sprintf(buf, "{\"type\":3,\"deviceId\":\"PROEVN\",\"time\":%d,\"cmdId\":%d,\"relay1\":%d,\"relay2\":%d,\"relay3\":%d}", |
DuyLionTran | 47:c3707a4f69a7 | 454 | inputTime, commandID, relay1, relay2, relay3); |
DuyLionTran | 32:8226837c56ae | 455 | message.qos = MQTT::QOS0; |
DuyLionTran | 32:8226837c56ae | 456 | message.retained = false; |
DuyLionTran | 32:8226837c56ae | 457 | message.dup = false; |
DuyLionTran | 32:8226837c56ae | 458 | message.payload = (void*)buf; |
DuyLionTran | 32:8226837c56ae | 459 | message.payloadlen = strlen(buf); |
DuyLionTran | 32:8226837c56ae | 460 | |
DuyLionTran | 32:8226837c56ae | 461 | if((message.payloadlen + strlen(pubTopic)+1) >= MQTT_MAX_PACKET_SIZE) |
DuyLionTran | 32:8226837c56ae | 462 | printf("message too long!\r\n"); |
DuyLionTran | 32:8226837c56ae | 463 | |
DuyLionTran | 32:8226837c56ae | 464 | LOG("Publishing %s\n\r", buf); |
DuyLionTran | 32:8226837c56ae | 465 | return client->publish(pubTopic, message); |
DuyLionTran | 32:8226837c56ae | 466 | } |
DuyLionTran | 32:8226837c56ae | 467 | |
DuyLionTran | 43:dcde0e66874a | 468 | int MQTT_PublishConfigValue(MQTT::Client<MQTTNetwork, Countdown, MQTT_MAX_PACKET_SIZE>* client, time_t inputTime, uint8_t mode, |
DuyLionTran | 43:dcde0e66874a | 469 | uint8_t OxyThreshold, uint8_t TemperatureThreshold, uint16_t UploadInterval) { |
DuyLionTran | 32:8226837c56ae | 470 | MQTT::Message message; |
DuyLionTran | 32:8226837c56ae | 471 | const char* pubTopic = MQTT_EVENT_TOPIC; |
DuyLionTran | 32:8226837c56ae | 472 | char buf[MQTT_MAX_PAYLOAD_SIZE]; |
DuyLionTran | 47:c3707a4f69a7 | 473 | // char timeBuf[50]; |
DuyLionTran | 32:8226837c56ae | 474 | |
DuyLionTran | 32:8226837c56ae | 475 | if (!client->isConnected()) { |
DuyLionTran | 32:8226837c56ae | 476 | printf ("---> MQTT DISCONNECTED\n\r"); |
DuyLionTran | 32:8226837c56ae | 477 | return MQTT::FAILURE; |
DuyLionTran | 32:8226837c56ae | 478 | } |
DuyLionTran | 47:c3707a4f69a7 | 479 | // strftime(timeBuf, 50, "%Y/%m/%d %H:%M:%S", localtime(&inputTime)); |
DuyLionTran | 48:a7ed665844cd | 480 | sprintf(buf, "{\"type\":4,\"deviceId\":\"PROEVN\",\"time\":%d,\"cmdId\":%d,\"mode\":%d,\"OxygenThreshold\":%d,\"TemperatureThreshold\":%d,\"uploadInterval\":%d}", |
DuyLionTran | 47:c3707a4f69a7 | 481 | inputTime, commandID, mode, OxyThreshold, TemperatureThreshold, UploadInterval); |
DuyLionTran | 32:8226837c56ae | 482 | message.qos = MQTT::QOS0; |
DuyLionTran | 32:8226837c56ae | 483 | message.retained = false; |
DuyLionTran | 32:8226837c56ae | 484 | message.dup = false; |
DuyLionTran | 32:8226837c56ae | 485 | message.payload = (void*)buf; |
DuyLionTran | 32:8226837c56ae | 486 | message.payloadlen = strlen(buf); |
DuyLionTran | 32:8226837c56ae | 487 | |
DuyLionTran | 32:8226837c56ae | 488 | if((message.payloadlen + strlen(pubTopic)+1) >= MQTT_MAX_PACKET_SIZE) |
DuyLionTran | 32:8226837c56ae | 489 | printf("message too long!\r\n"); |
DuyLionTran | 32:8226837c56ae | 490 | |
DuyLionTran | 32:8226837c56ae | 491 | LOG("Publishing %s\n\r", buf); |
DuyLionTran | 32:8226837c56ae | 492 | return client->publish(pubTopic, message); |
DuyLionTran | 32:8226837c56ae | 493 | } |
DuyLionTran | 32:8226837c56ae | 494 | |
DuyLionTran | 32:8226837c56ae | 495 | int MQTT_PublishAll(MQTT::Client<MQTTNetwork, Countdown, MQTT_MAX_PACKET_SIZE>* client, time_t inputTime, uint8_t uploadType, struct UploadValue uploadStruct) { |
DuyLionTran | 32:8226837c56ae | 496 | int retVal; |
DuyLionTran | 32:8226837c56ae | 497 | switch (uploadType) { |
DuyLionTran | 36:d0b628087ac8 | 498 | case (ADC_VALUE): retVal = MQTT_PublishADC(client, inputTime, uploadStruct.ADC_DOVal); |
DuyLionTran | 32:8226837c56ae | 499 | break; |
DuyLionTran | 43:dcde0e66874a | 500 | case (SENSOR_VALUE): retVal = MQTT_PublishSensorVal(client, inputTime, uploadStruct.SENSOR_TEMPVal ,uploadStruct.SENSOR_DOVal); |
DuyLionTran | 32:8226837c56ae | 501 | break; |
DuyLionTran | 36:d0b628087ac8 | 502 | case (RELAY_STATE): retVal = MQTT_PublishRelayState(client, inputTime, uploadStruct.RELAY_State_1, uploadStruct.RELAY_State_2, uploadStruct.RELAY_State_3); |
DuyLionTran | 32:8226837c56ae | 503 | break; |
DuyLionTran | 43:dcde0e66874a | 504 | case (CONFIG_VALUE): retVal = MQTT_PublishConfigValue(client, inputTime, uploadStruct.CONFIG_Mode, uploadStruct.CONFIG_OxyThreshold, uploadStruct.CONFIG_TemperatureThreshold, uploadStruct.CONFIG_UploadInterval); |
DuyLionTran | 32:8226837c56ae | 505 | break; |
DuyLionTran | 32:8226837c56ae | 506 | default: break; |
DuyLionTran | 32:8226837c56ae | 507 | } |
DuyLionTran | 32:8226837c56ae | 508 | return retVal; |
DuyLionTran | 32:8226837c56ae | 509 | } |
DuyLionTran | 32:8226837c56ae | 510 | |
DuyLionTran | 32:8226837c56ae | 511 | #endif /* __SIMPLEMQTT_H__ */ |