#include <pigpio.h>
#define I2C_ADDR 0x48 // 上面跳线所选择的地址#define I2C_CONFIG_HI 0xC4 // I2C的配置高位字节#define I2C_CONFIG_LO 0x83 // I2C的配置低位字节#define I2C_CONFIG_REG 0x01 // 配置数据写入寄存器
static float get_humidty_value (){ // 初始化pigpio库 if ( gpioInitialise() < 0 ) { log_error ( "GPIO initialize failed." ); return -1; }
 // 打开I2C int i2c_handle = i2cOpen ( 1, I2C_ADDR, 0 ); if ( i2c_handle < 0 ) { log_error ( "I2C open failed, error no: %d", i2c_handle ); return -1; }
 // 写入配置数据，对I2C进行配置 char config[2] = { I2C_CONFIG_HI, I2C_CONFIG_LO }; int config_res = i2cWriteI2CBlockData(i2c_handle, I2C_CONFIG_REG, config, 2); if ( config_res != 0 ) { switch ( config_res ) { case PI_I2C_WRITE_FAILED: log_error ( "I2C write failed." ); break; case PI_BAD_HANDLE: log_error ( "I2C write bad handle."); break; case PI_BAD_PARAM: log_error ( "I2C write bad parameter." ); break; }
 return -1; }
 time_sleep ( 0.2 );
 // 从I2C读入数据并保存在一个字节数组中 char data[2]; int num_bytes_read = i2cReadI2CBlockData ( i2c_handle, 0x00, data, 2 ); if ( num_bytes_read <= 0 ) { switch ( num_bytes_read ) { case PI_I2C_READ_FAILED: log_error ( "I2C read failed." ); break; case PI_BAD_HANDLE: log_error ( "I2C read bad handle."); break; case PI_BAD_PARAM: log_error ( "I2C read bad parameter." ); break; }
 return -1; }
 // 通过字节数组数据的拼装，得到湿度数据 float result = (data[0] << 8) | data[1]; // 计算出电压值，仅作日志输出参考使用 float voltage = result * 2.048 / 32768.0; log_info ( "ADC value: %.3f, Voltage: %.3f", result, voltage );
 i2cClose ( i2c_handle ); gpioTerminate ( );
 // 将结果返回 return result;}

#include <stdio.h>#include <stdlib.h>#include <sys/stat.h>#include <azureiot/iothub.h>#include <azureiot/iothub_client_version.h>#include <azureiot/iothub_device_client_ll.h>#include <azureiot/iothubtransportmqtt.h>#include <azure_c_shared_utility/threadapi.h>
#define CONNECTION_STRING_NAME "IOTHUB_CONNECTION_STRING"
// 发送出去的消息数目static int g_message_count_send_confirmations = 0;
// 消息发送之后的确认回调static void send_confirm_callback ( IOTHUB_CLIENT_CONFIRMATION_RESULT result, void* userContextCallback ){ g_message_count_send_confirmations++; log_info ( "Confirmation callback received for message %lu with status %s",  ( unsigned long )g_message_count_send_confirmations,  MU_ENUM_TO_STRING(IOTHUB_CLIENT_CONFIRMATION_RESULT, result)  );}
// 与Azure IoT Hub建立连接后的回调static void connection_status_callback(IOTHUB_CLIENT_CONNECTION_STATUS result,  IOTHUB_CLIENT_CONNECTION_STATUS_REASON reason,  void* user_context){ if ( result == IOTHUB_CLIENT_CONNECTION_AUTHENTICATED ) log_info ( "The device client is connected to iothub." ); else log_info ( "The device client has been disconnected." );}
// 发送数据static void send_message ( IOTHUB_DEVICE_CLIENT_LL_HANDLE handle, RPI_MESSAGE_HANDLE message_handle ){ const char* serialized_message = Rpi_SerializeMessage ( message_handle ); log_debug ( "Message: %s", serialized_message );
 IOTHUB_MESSAGE_HANDLE iot_message_handle = IoTHubMessage_CreateFromString( serialized_message ); if ( iot_message_handle ==  ) { log_error ( "Failed to create message handle from String." ); return; }
 IOTHUB_MESSAGE_RESULT send_res = IoTHubClientCore_LL_SendEventAsync ( handle, iot_message_handle, send_confirm_callback,  ); if ( send_res != IOTHUB_MESSAGE_OK ) { log_error ( "IoTHubClientCore_LL_SendEventAsync call failed with status %s", MU_ENUM_TO_STRING ( IOTHUB_CLIENT_RESULT, send_res ) ); } else { do { IoTHubDeviceClient_LL_DoWork ( handle ); ThreadAPI_Sleep ( 1 ); } while (g_message_count_send_confirmations < 1);
 g_message_count_send_confirmations = 0; }
 IoTHubMessage_Destroy ( iot_message_handle );}
int main ( int argc, char** argv ){ // 从环境变量或者命令行获得Azure IoT Hub的连接字符串 const char* iothub_connection_string = getenv ( CONNECTION_STRING_NAME ); if ( iothub_connection_string ==  ) { if ( argc == 2 ) { iothub_connection_string = argv[1]; }
 if ( iothub_connection_string ==  ) { log_error ( "Error: Missing IOTHUB_CONNECTION_STRING environment variable. Terminated." ); fclose ( fp_log ); return -1; } }
 // 初始化IoT C SDK库 int init_res = IoTHub_Init();
 if ( init_res != 0 ) { log_error ( "IoT Hub initialize failed." ); fclose ( fp_log ); return -1; }
 log_info ( "IoT Hub client version: %s", IoTHubClient_GetVersionString() );
 // 创建设备连接 IOTHUB_DEVICE_CLIENT_LL_HANDLE device_handle = IoTHubDeviceClient_LL_CreateFromConnectionString ( iothub_connection_string, MQTT_Protocol ); if ( device_handle ==  ) { log_error ( "Can't get device client handle. Check connection string." ); fclose ( fp_log ); return -1; }
 IoTHubDeviceClient_LL_SetConnectionStatusCallback ( device_handle, connection_status_callback,  );
 // 获取湿度值 float humidty_val = get_humidty_value ( ); if ( humidty_val > 0 ) { // 基于湿度值构建一条待发送的消息 RPI_MESSAGE_HANDLE message = Rpi_CreateMessage ( humidty_val ); // 将消息发送到IoT Hub send_message ( device_handle, message ); // 释放消息所占用的资源 Rpi_DestroyMessage ( message ); } else { log_error ( "Message was not sent due to a failure in getting humidty value." ); }
 // 关闭IoT Hub连接并释放资源 IoTHubDeviceClient_LL_Destroy ( device_handle ); // 释放IoT Hub C SDK资源 IoTHub_Deinit();
 fclose ( fp_log ); return 0;}

sudo crontab -e

*/15 * * * * /home/daxnet/projects/humidty/src/iot/main "<iot_hub_connection_string>"

gcc -Wall -fdiagnostics-color=always -g main.c rpi_message.c log.c -o main \-liothub_client -liothub_client_mqtt_transport -lumqtt -lprov_device_client \-lprov_auth_client -lhsm_security_client -lutpm -laziotsharedutil -lpthread \-lcurl -lssl -lcrypto -lm -lparson -lprov_mqtt_transport -lpigpio -lrt

public class HumidtyStoringFunction(ILogger<HumidtyStoringFunction> logger){ private const string DatabaseTableName = "public.humidty_history";
 [Function("humidty_storing_function")] public void Run([EventHubTrigger( "iothub-ehub-humidty-io-56972526-7565e081a6", Connection = "ConnectionStringSetting")] EventData[] events) { var dbConnectionString = Environment.GetEnvironmentVariable("PostgresConnectionString"); if (string.IsOrWhiteSpace(dbConnectionString)) { logger.LogError("Database connection string is not specified, function will not proceed."); return; }
 try { // 初始化PostgreSQL连接 using var sqlConnection = new NpgsqlConnection(dbConnectionString);
 // 对于收到的每一个事件（消息） foreach (var @event in events) { var eventJson = Encoding.UTF8.GetString(@event.EventBody); logger.LogInformation($"Processing event {eventJson}"); var jobject = JObject.Parse(eventJson); // 获得时间和湿度值 var t = jobject.GetValue("t")?.Value<long>(); var v = jobject.GetValue("v")?.Value<double>(); if (t is  || v is ) { logger.LogError("Event received but the content is incorrect, function will not proceed."); return; }
 // 将时间和湿度值插入数据库 var sql = $@"INSERT INTO {DatabaseTableName} (""time"", ""value"") VALUES ({t}, {v})"; sqlConnection.Execute(sql);
 logger.LogInformation("Event processed successfully."); } } catch (Exception e) { // 如果出错，则写日志，并抛出 logger.LogError(e, "Failed to process event, exception details as below..."); throw; } }}

$(document).ready(function(){ $.ajax({ type: "GET", url: "/?handler=AISuggestion", contentType: "application/json", dataType: "json", success: function (result) { $('#aiSuggestion').html(result); } });});

public async Task<JsonResult> OnGetAISuggestionAsync(){ var startTime = DateTime.Now.AddDays(-7); var endTime = DateTime.Now; var recentHumidtyData = await Utils.GetHumidtyHistory(startTime, endTime, _connectionString); var avgHumidtyData = recentHumidtyData .GroupBy(h => h.Time / 3600 / 6) .Select(g => new HumidtyHistory { Time = g.First().Time, Value = g.Average(h => h.Value) }) .ToDictionary(h => Utils.UnixTimestampToLocalDateTime(h.Time), h => h.Value); var sb = new StringBuilder(); sb.AppendLine("下面最近7天内每6小时的平均数据趋势：");
 var sbResponse = new StringBuilder(); foreach (var kvp in avgHumidtyData) { sb.AppendLine($"时间：{kvp.Key.ToShortDateString()} {kvp.Key.ToShortTimeString()}，数据：{kvp.Value}"); }
 sb.AppendLine($""" 数据越接近31840，表明冬眠箱越干燥，越需要补水，数据越接近0，表明冬眠箱越湿润，不需要补水。 现在时间是{DateTime.Now.ToShortDateString()} {DateTime.Now.ToShortTimeString()}，请预测乌龟冬眠箱补水的大致时间。 """); _chat.Clear(); _chat.AddUserMessage(sb.ToString()); await foreach (var message in _chatCompletionService.GetStreamingChatMessageContentsAsync(_chat)) { sbResponse.AppendLine(message.Content); }
 return new JsonResult(sbResponse.ToString());}