Master in ASP.Net And Sql: How to Send Mail and sms Using Azure Web Job and Storage Queue?

Note: First Message will save on Database and after that that message will send to Queue. Before that, we will go to azure portal and Storage Account. In Storage Account on Queue we are creating, a queue name is mailsending and smssending.

Next, Declare a Class file for SMS and mail sending and Class Name is SendOTPToStorageQueueService.

In addition, write below code

using Satya.Models;

using Microsoft.WindowsAzure.Storage;

using Microsoft.WindowsAzure.Storage.Queue;

using Newtonsoft.Json;

using System;

using System.Collections.Generic;

using System.Diagnostics;

using System.Linq;

using System.Net.Http;

using System.Net.Http.Headers;

using System.Web;

namespace Satya.Utils

{

public class SendOTPToStorageQueueService

{

public SendOTPToStorageQueueService()

{

var url = "http://satyamasterapi.azurewebsites.net/api/"; // for API

client.BaseAddress = new Uri(url);

client.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));

}

HttpClient client = new HttpClient();

public int OTPSendDetails(string mid, string mobno, string sss)

{

string mode = "Mobile";

Master_OTPSendDetail otpInfo = new Master_OTPSendDetail();

otpInfo.User_RegistrationId = 1;

if (mode == "email")

{

otpInfo.IsEmail = true;

otpInfo.IsMobile = false;

}

else

{

otpInfo.IsEmail = false;

otpInfo.IsMobile = true;

}

otpInfo.SendFrom = "satya";

otpInfo.SendTO = mobno;

otpInfo.MessageId = "1";

otpInfo.OTP = sss;

otpInfo.DeliveryStatus = "Fail";

otpInfo.InsertedOn = DateTime.Now;

otpInfo.InsertedBy = 1;

HttpResponseMessage res = client.PostAsJsonAsync("MasterOTPSendDetail", otpInfo).Result;

int Master_OTPDetailId = Convert.ToInt32(res.Content.ReadAsStringAsync().Result);

CloudStorageAccount storageAccount = CloudStorageAccount.Parse("DefaultEndpointsProtocol=https;AccountName=satyadmin;AccountKey=I/mTWtgGpgiDTgqF45BrOwI8dssdsd9wjwtv8/dsdsdsds+ASJ9Uid3z4NqQ==");

CloudQueueClient queueClient = storageAccount.CreateCloudQueueClient();

CloudQueue queue = queueClient.GetQueueReference("smssending");

queue.CreateIfNotExists();

Master_MobileOTPMessage sendsmsMessage = new Master_MobileOTPMessage() { Message_Id = 1, Message = sss, MobileNo = mobno, IsSend = false };

queue.AddMessage(new CloudQueueMessage(JsonConvert.SerializeObject(sendsmsMessage)));

Trace.TraceInformation("Created queue message for AdId {0}", mid);

return Master_OTPDetailId;

}

public int MailSendDetails(string mid, string frommailid, string tomailid, string sss, bool isSend)

{

string mode = "email";

Master_OTPSendDetail otpInfo = new Master_OTPSendDetail();

otpInfo.User_RegistrationId = null;

if (mode == "email")

{

otpInfo.IsEmail = true;

otpInfo.IsMobile = false;

}

else

{

otpInfo.IsEmail = false;

otpInfo.IsMobile = true;

}

otpInfo.SendFrom = frommailid;

otpInfo.SendTO = tomailid;

otpInfo.MessageId = "1";

otpInfo.OTP = sss;

otpInfo.DeliveryStatus = "Fail";

otpInfo.InsertedOn = DateTime.Now;

otpInfo.InsertedBy = 1;

otpInfo.IsActive = true;

otpInfo.IsDelete = false;

HttpResponseMessage res = client.PostAsJsonAsync("MasterOTPSendDetail", otpInfo).Result;

int Master_OTPDetailId = Convert.ToInt32(res.Content.ReadAsStringAsync().Result);

CloudStorageAccount storageAccount = CloudStorageAccount.Parse("DefaultEndpointsProtocol=https;AccountName=satyadmin;AccountKey=I/mTWtgGpgiDTgqF45BrOwI8dssdsd9wjwtv8/dsdsdsds+ASJ9Uid3z4NqQ==");

CloudQueueClient queueClient = storageAccount.CreateCloudQueueClient();

CloudQueue queue = queueClient.GetQueueReference("mailsending");

queue.CreateIfNotExists();

Master_MailOTPMessage sendsmsMessage = new Master_MailOTPMessage() { Message_Id = 1, FromEmailId = frommailid, ToEmailId = tomailid, Message = sss, IsSend = false };

queue.AddMessage(new CloudQueueMessage(JsonConvert.SerializeObject(sendsmsMessage)));

Trace.TraceInformation("Created queue message for AdId {0}", mid);

return Master_OTPDetailId;

}

Next, Add Web Job for Mail Sending. (Storage Account connection String)

In App Config File

</connectionStrings>

Go TO Functions

using System;

using System.Collections.Generic;

using System.IO;

using System.Linq;

using System.Text;

using System.Threading.Tasks;

using Microsoft.Azure.WebJobs;

using System.Net.Mail;

namespace satyaMailSendingWebJOB

{

public class Functions

{

// This function will get triggered/executed when a new message is written

// on an Azure Queue called queue.

//public static void ProcessQueueMessage([QueueTrigger("mailsending")] string message, TextWriter log)

//{

public static void ProcessQueueMessage([QueueTrigger("mailsending")] Master_MailOTPMessage mailmessage, TextWriter log)

{

MailSender(mailmessage.Message_Id, mailmessage.FromEmailId, mailmessage.ToEmailId, mailmessage.Message, mailmessage.IsSend);

// log.WriteLine(message);

}

public static void MailSender(int Message_Id, string FromEmailId, string ToEmailId, string message, bool IsSend)

{

MailMessage msg = new MailMessage();

msg.To.Add(new MailAddress(ToEmailId));

msg.From = new MailAddress("satya@gmail.com ", "satya company");

msg.Subject = "Test Mail";

string body = "Dear User, ";

body += " Please use " + message + " " + "as the Onte Time Password, Please do not share this anyone. This Password is valid for 2 minutes.";

body += " For Further Queries , please write us at satya@gmail.com (satya@gmail.com) or call us at our given contact.";

body += " Regards";

body += " satya@gmail.com TEAM ";

msg.Body = body; //"Test message using smtp.office365.com on Azure from a Web App";

msg.IsBodyHtml = true;

SmtpClient client = new SmtpClient();

client.UseDefaultCredentials = false;

client.Credentials = new System.Net.NetworkCredential("satya@gmail.com", "satya2018");

client.Port = 587;

client.Host = " satya@gmail.com ";

client.DeliveryMethod = SmtpDeliveryMethod.Network;

client.EnableSsl = true;

try

{

client.Send(msg);

}

catch (Exception ex)

{

}

Next In Program.cs

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Threading.Tasks;

using Microsoft.Azure.WebJobs;

namespace satyaMailSendingWebJOB

{

// To learn more about Microsoft Azure WebJobs SDK, please see https://go.microsoft.com/fwlink/?LinkID=320976

class Program

{

// Please set the following connection strings in app.config for this WebJob to run:

// AzureWebJobsDashboard and AzureWebJobsStorage

static void Main()

{

var config = new JobHostConfiguration();

if (config.IsDevelopment)

{

config.UseDevelopmentSettings();

}

var host = new JobHost(config);

// The following code ensures that the WebJob will be running continuously

host.RunAndBlock();

}

Next, Add Web Job for SMS Sending. (Storage Account connection String)

In App Config File

</connectionStrings>

Go TO Functions

using System;

using System.Collections.Generic;

using System.IO;

using System.Linq;

using System.Text;

using System.Threading.Tasks;

using Microsoft.Azure.WebJobs;

using Newtonsoft.Json.Linq;

using RestSharp;

namespace satyaSmsSendingsWebJob

{

public class Functions

{

// This function will get triggered/executed when a new message is written

// on an Azure Queue called queue.

public static void ProcessQueueMessage([QueueTrigger("smssending")] Master_MobileOTPMessage message, TextWriter log)

{

SMSSender(message.Message_Id, message.Message, message.MobileNo, message.IsSend);

}

public static void SMSSender(int Message_Id, string Message, string MobileNo, bool IsSend)

{

var jsonObject = new JObject

{

{"from", "satya"},

{"to","91"+MobileNo},

{"text",Message+" "+"is OTP for your satya Registration. OTP Valid for 2 minutes. Do not share this OTP with anyone."},

};

string sss = EncodingForBase64.Base64Encode("satya:satya@1234");

// string authEncoded = EncodingForBase64.base64_encode('myuserame:password');

var client = new RestClient("https://api.infobip.com/sms/1/text/single");

var request = new RestRequest(Method.POST);

request.AddHeader("accept", "application/json");

request.AddHeader("content-type", "application/json");

request.AddHeader("authorization", "Basic " + sss);

request.AddParameter("application/json", jsonObject, ParameterType.RequestBody); //"{\"from\":\"InfoSMS\", \"to\":\"9040049188\",\"text\":\"Test SMS.\"}", ParameterType.RequestBody);

IRestResponse response = client.Execute(request);

}

Next in Program.cs

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Threading.Tasks;

using Microsoft.Azure.WebJobs;

namespace SatyaSmsSendingsWebJob

{

// To learn more about Microsoft Azure WebJobs SDK, please see https://go.microsoft.com/fwlink/?LinkID=320976

class Program

{

//Please set the following connection strings in app.config for this WebJob to run:

// AzureWebJobsDashboard and AzureWebJobsStorage

static void Main()

{

var config = new JobHostConfiguration();

if (config.IsDevelopment)

{

config.UseDevelopmentSettings();

}

var host = new JobHost(config);

// The following code ensures that the WebJob will be running continuously

host.RunAndBlock();

}

//static void Main(string[] args)

//{

// JobHost host = new JobHost();

// host.RunAndBlock();

//}

}

Master in ASP.Net And Sql

Wednesday 22 August 2018

How to Send Mail and sms Using Azure Web Job and Storage Queue?

No comments:

Post a Comment