in Source/Function/EnrollmentVerificator.cs [195:225]
public static async Task RunUpdateEnrollmentStatus(
[ActivityTrigger] UpdateStatus dataStatus,
ILogger log)
{
// Get the connection string from app settings and use it to create a connection.
var str = Environment.GetEnvironmentVariable("sqldb_connection");
using (SqlConnection conn = new SqlConnection(str))
{
conn.Open();
var text = $"UPDATE dbo.Customers " +
"SET [Enrrolled] = @enrollment WHERE CustomerId = @customerId";
using (SqlCommand cmd = new SqlCommand(text, conn))
{
cmd.Parameters.AddWithValue("@enrollment", dataStatus.Status);
cmd.Parameters.AddWithValue("@customerId", dataStatus.CustomerId);
var rows = await cmd.ExecuteNonQueryAsync();
if (rows > 0)
{
log.LogInformation($"User with Id: {dataStatus.CustomerId} updated to EnrollmentStatus: {dataStatus.Status}");
}
else
{
log.LogInformation($"No changes applied for User with Id: {dataStatus.CustomerId}");
}
}
}
}