跟踪数据库保存在“实时"数据库中的进度.进度栏asp.net mvc [英] track the progress of a database save in a "live" progress bar asp.net mvc
本文介绍了跟踪数据库保存在“实时"数据库中的进度.进度栏asp.net mvc的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！
问题描述
我需要显示.net 4.5中SQL加载的进度.目的是显示上传的实时"流程.这样，上传信息的人就可以看到上传正常.
I need to show the progress of a SQL load in .net 4.5. The objective is to show a "Live" flow of the uploads happening. So that the person uploading the information can see that the upload is working.
控制器方法:
private void ProgressUpload(int? SystemGeneralAnnouncementId) {
var systemGeneralAnnouncement = (SystemGeneralAnnouncementId == null) ? null : _uow.SystemGeneralAnnouncementRepository.GetById(SystemGeneralAnnouncementId.Value);
List<Status> status = new List<Status>();
if (systemGeneralAnnouncement.Statuses.Length > 0)
{
status.AddRange(systemGeneralAnnouncement.Statuses.Split(',').Select(item => (Status)Enum.Parse(typeof(Status), item)));
}
var allEmailAddresses = new List<PointOfContact>();
var EmailAddresses = new List<PointOfContact>();
//retrieve all Point of contact based upon selected statuses per each loop
var result = new List<PointOfContact>();
foreach (var item in status)
{
result = _uow.PointOfContactRepository.GetAllByStatus(item).ToList();
allEmailAddresses.AddRange(result);
}
// Retrieve the email addresses based on the who is intended to receive the email message
if (systemGeneralAnnouncement.SendToRecipients.Contains("(1) All Three Contacts"))
{
EmailAddresses = allEmailAddresses;
}
else
{
if (systemGeneralAnnouncement.SendToRecipients.Contains("(2) All first Contacts"))
{
pocEmailAddresses.AddRange(allEmailAddresses.Where(r => r.PointOfContactType == PointOfContactTypes.Primary).ToList());
}
if (systemGeneralAnnouncement.SendToRecipients.Contains("(3) All Second Contacts"))
{
pocEmailAddresses.AddRange(allEmailAddresses.Where(r => r.PointOfContactType == PointOfContactTypes.Secondary).ToList());
}
if (systemGeneralAnnouncement.SendToRecipients.Contains("(4) All third contacts"))
{
pocEmailAddresses.AddRange(allEmailAddresses.Where(r => r.PointOfContactType == PointOfContactTypes.SigningAuthority).ToList());
}
if (systemGeneralAnnouncement.SendToRecipients.Contains("(5) All fourth Contacts"))
{
pocEmailAddresses.AddRange(allEmailAddresses.Where(r => r.PointOfContactType == PointOfContactTypes.TuitionRates).ToList());
}
if (systemGeneralAnnouncement.SendToRecipients.Contains("(6) Specified Email Address"))
{
var pocs = new List<PointOfContact>();
string[] emails = systemGeneralAnnouncement.EmailAddresses.Split(',');
foreach (string email in emails)
{
var addPoc = new PointOfContact { Email = email };
User user = _uow.UserRepository.GetByEmail(email);
if (user == null)
{
add.FirstName = "Not Created Account Yet";
}
else
{
addPoc.FirstName = user.FirstName;
addPoc.LastName = user.LastName;
}
List<PointOfContact> idAssociatedToUser =
_uow.PointOfContactRepository
.GetAllPocsByEmail(email)
.ToList();
if (idAssociatedToUser.Count == 0)
{
addPoc.IDNumber = "N/A";
}
else
{
string[] idArray = idAssociatedToUser
.Select(x => x.IDNumber)
.ToArray();
addPoc.IDNumber = string.Join(",", opeidArray);
}
pocs.Add(addPoc);
}
EmailAddresses.AddRange(pocs);
}
}
// if any poc addresses were found...
if (EmailAddresses.Count > 0)
{
string emailBody = WebUtility.HtmlDecode(systemGeneralAnnouncement.EmailBody);
foreach (PointOfContact emailAddress in EmailAddresses.Where(x => x.Email != "" && x.Email != null).ToList())
{
string firstName = emailAddress.FirstName == null ? "" : emailAddress.FirstName.Trim();
string lastName = emailAddress.LastName == null ? "" : emailAddress.LastName.Trim();
string userName = firstName + " " + lastName;
//Below I Used SqlCommand vs EF because EF has AutoDetectChangesEnabled and it slows things down when adding to the context. Instead of tuning it by turning it to false or
//configure it to use AddRange, SqlCommand is the best option for speed.
保存到数据库:
SaveToDatabase(emailAddress.Email, emailBody, systemGeneralAnnouncement.Subject, UserIdentityHelper.GetUserEmailAddress + " (" + UserIdentityHelper.GetUserId + ")", systemGeneralAnnouncement.SystemGeneralAnnouncementId, userName, emailAddress.IDNumber);
LogInstitutionEmail(systemGeneralAnnouncement.Subject, emailBody, emailAddress.Email, emailAddress.IDNumber, systemGeneralAnnouncement.EmailAttachmentLocation);
}
}
}
private void LogInstitutionEmail(string subject, string emailBody, string email, string opeidNumber, string emailAttachment)
{
try
{
using (var conn = new SqlConnection(ConfigurationManager.ConnectionStrings["MasterContext"].ConnectionString))
{
conn.Open();
SqlCommand cmd;
if (string.IsNullOrEmpty(emailAttachment))
{
cmd = new SqlCommand("Insert Into Emails (Since, Subject, Email, EmailAddress, OpeidNumber, FirstReadDateTime) VALUES(@Since, @Subject, @Email, @EmailAddress, @OpeidNumber, NULL)", conn);
}
else
{
cmd = new SqlCommand("Insert Into Emails (Since, Subject, Email, EmailAddress, OpeidNumber, FirstReadDateTime, Attachment) VALUES(@Since, @Subject, @Email, @EmailAddress, @IDNumber, NULL, @Attachment)", conn);
cmd.Parameters.Add(new SqlParameter() { ParameterName = "@Attachment", Value = emailAttachment });
}
cmd.Parameters.Add(new SqlParameter() { ParameterName = "@Since", Value = DateTime.Now });
cmd.Parameters.Add(new SqlParameter() { ParameterName = "@Subject", Value = subject });
cmd.Parameters.Add(new SqlParameter() { ParameterName = "@Email", Value = emailBody });
cmd.Parameters.Add(new SqlParameter() { ParameterName = "@EmailAddress", Value = email });
cmd.Parameters.Add(new SqlParameter() { ParameterName = "@idNumber", Value = idNumber });
cmd.CommandType = CommandType.Text;
cmd.ExecuteNonQuery();
conn.Close();
}
}
catch (Exception ex)
{
Elmah.ErrorSignal.FromCurrentContext().Raise(ex);
}
}
private void SaveToDatabase(string emailRecipient, string emailBody, string subject, string userWhoSentIt, int systemGeneralAnnouncementId, string userName, string opeidNumber)
{
try
{
using (var conn = new SqlConnection(ConfigurationManager.ConnectionStrings["MasterContext"].ConnectionString))
{
conn.Open();
var cmd = new SqlCommand("Insert Into EmailQueue (EmailRecipients, EmailBody, EmailSubject, UserWhoSentIt, QueueDate, SystemGeneralAnnouncementId, UserName, OpeidNumber) VALUES(@EmailRecipients, @EmailBody, @EmailSubject, @UserWhoSentIt, @QueueDate, @SystemGeneralAnnouncementId, @UserName, @OpeidNumber)", conn);
cmd.CommandType = CommandType.Text;
cmd.Parameters.Add(new SqlParameter() {ParameterName = "@EmailRecipients", Value = emailRecipient });
cmd.Parameters.Add(new SqlParameter() { ParameterName = "@EmailBody", Value = emailBody });
cmd.Parameters.Add(new SqlParameter() { ParameterName = "@EmailSubject", Value = subject });
cmd.Parameters.Add(new SqlParameter() { ParameterName = "@UserWhoSentIt", Value = userWhoSentIt });
cmd.Parameters.Add(new SqlParameter() { ParameterName = "@QueueDate", Value = DateTime.Now });
cmd.Parameters.Add(new SqlParameter() { ParameterName = "@SystemGeneralAnnouncementId", Value = systemGeneralAnnouncementId });
cmd.Parameters.Add(new SqlParameter() { ParameterName = "@UserName", Value = userName });
cmd.Parameters.Add(new SqlParameter() { ParameterName = "@idNumber", Value = idNumber });
cmd.ExecuteNonQuery();
conn.Close();
}
}
catch (Exception ex)
{
Elmah.ErrorSignal.FromCurrentContext().Raise(ex);
}
}
调用Post方法的视图:
View that calls Post Method:
@model DODMOU.Model.Entities.SystemGeneralAnnouncement
@{
ViewBag.Title = "Send Email";
Layout = "~/Views/Shared/_AdministratorLayout.cshtml";
}
<div class="title">
<h2>Send Email</h2>
</div>
<hr />
<div class="title">
<h2>Are you sure you want to Send this Email?</h2>
</div>
<div class="row">
<div class="col-sm-offset-2 col-sm-9">
<table class="table table-striped table-hover table-bordered table-responsive">
<tr>
<th scope="row" class="col-md-1">@Html.DisplayNameFor(model => model.SendToRecipients) :</th>
<td class="col-md-8">@Html.DisplayFor(model => model.SendToRecipients)</td>
</tr>
<tr>
<th scope="row">@Html.DisplayNameFor(model => model.Subject) :</th>
<td>@Html.DisplayFor(model => model.Subject)</td>
</tr>
<tr>
<th scope="row">@Html.DisplayNameFor(model => model.EmailBody) :</th>
<td class="col-sm-8">@MvcHtmlString.Create(HttpUtility.HtmlDecode(Model.EmailBody))</td>
</tr>
<tr>
<th scope="row">@Html.DisplayNameFor(model => model.Since) :</th>
<td>@Html.DisplayFor(model => model.Since)</td>
</tr>
</table>
</div>
<div class="row col-sm-offset-2 col-sm-9 text-right">
<div class="row col-sm-offset-2 col-sm-9 text-right">
@using (Html.BeginForm("ConfirmSend", "SystemGeneralAnnouncement", FormMethod.Post))
{
@Html.AntiForgeryToken()
@Html.HiddenFor(model => model.SystemGeneralAnnouncementId)
<div class="form-actions no-color">
<input type="submit" value="Send" class="btn btn-primary" /> |
@Html.ActionLink("Back to List", "Index")
</div>
}
</div>
</div>
</div>
接收上传信息的视图:
<div class="col-xs-12" style="text-align: center">
<p>
<div class="alert alert-success Loading">
<h2 class="title">General Announcement is Loading...</h2>
<br />
</div>
The selected general announcements are being uploaded...<br />
<div class="progress"> <div class="progress-bar" role="progressbar" aria-valuenow="0" aria-valuemin="0" aria-valuemax="100" style="width: 0%;"></div> </div>
@Html.ActionLink("Return to the System General Announcement page.", "Index", "SystemGeneralAnnouncement")
</p>
<div id="success" style="display:none">
<div class="alert alert-success">
<h2 class="title">General Announcement Successfully Generated!</h2>
</div>
The selected general announcement has been successfully generated and will begin sending to the appropriate recipients within the next few minutes.<br />
@Html.ActionLink("Return to the System General Announcement page.", "Index", "SystemGeneralAnnouncement")
</div>
</div>
@section scripts{
<script>
$.ajax({
type: 'POST',
url: "ProgressUpload, systemGeneralAnnouncement",
data: {},
success: function (data) {
$(".Loading").hide();
$("#success").css("display","block");
},
xhr: function () {
var xhr = new window.XMLHttpRequest();
xhr.upload.addEventListener("progress", function (evt) {
if (evt.lengthComputable) {
var percentComplete = evt.loaded / evt.total;
}
}, false);
return xhr;
},
});
</script>
}
如上所述，此处的最终目标是允许用户在文件上传时看到页面上的实时"进度. 100％之后将显示成功回报，以告知他们上传已完成.
The end goal here, as stated above is to allow the user to see the "live" progress on the page as the files are being uploaded. The success return is going to show after the 100% to let them know that the upload completed.
我的问题是，我不知道要公开要上传的当前值吗?它应来自事件侦听器，但在上传时不显示任何进度.
My question is, what am I missing to expose the current values to upload? it should come from the event listener, but does not show any progress on upload.
推荐答案
我建议使用SignalR将进度数据更新到客户端.
假设您的上传数据为IEnumerable类型，则需要在foreach循环中捕获对DB的每次更新，并使用SignalR将数据更新到客户端.
I am suggesting using SignalR to update progress data to Client.
Assuming your upload data is IEnumerable type, you need to catch in in foreach loop every updating to DB and update data to client using SignalR.
请参阅此链接: https://www.codeproject. com/Articles/1124691/SignalR-Progress-Bar-Simple-Example-Sending-Live-D
这篇关于跟踪数据库保存在“实时"数据库中的进度.进度栏asp.net mvc的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！
查看全文
