|
|
|
@ -318,4 +318,240 @@ FROM (SELECT A.*, |
|
|
|
return ServiceResult.OprateSuccess("执行成功！"); |
|
|
|
return ServiceResult.OprateSuccess("执行成功！"); |
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
#region Excel导入 |
|
|
|
|
|
|
|
public override async Task<ServiceResult<string>> DownloadExcel(string menuName) |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
var physicsPath = $"{Environment.CurrentDirectory}{Path.DirectorySeparatorChar}wwwroot"; |
|
|
|
|
|
|
|
var path = $"{$"{Path.DirectorySeparatorChar}files{Path.DirectorySeparatorChar}ExcelTemplate{Path.DirectorySeparatorChar}"}"; |
|
|
|
|
|
|
|
if (!Directory.Exists(physicsPath + path)) |
|
|
|
|
|
|
|
Directory.CreateDirectory(physicsPath + path); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
Type entityType = typeof(Ghre_Teacher); |
|
|
|
|
|
|
|
var fileName = entityType.GetEntityTableName() + ".xlsx"; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
var physicsPath1 = physicsPath + path + fileName; |
|
|
|
|
|
|
|
//if (dataSourceLists.Any()) |
|
|
|
|
|
|
|
// physicsPath1 = physicsPath + path + newFileName; |
|
|
|
|
|
|
|
var result = ServiceResult<string>.OprateSuccess("讲师维护_" + DateTimeHelper.ConvertToSecondString1(DateTime.Now) + ".xlsx", physicsPath1); |
|
|
|
|
|
|
|
return result; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
public override async Task<ServiceResult<ExcelData>> ImportExcel(IFormFile file, string menuName = null, long? MasterId = null) |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
var data = new ExcelData(); |
|
|
|
|
|
|
|
long id = SnowFlakeSingle.instance.getID(); |
|
|
|
|
|
|
|
var physicsPath = $"{Environment.CurrentDirectory}{Path.DirectorySeparatorChar}wwwroot"; |
|
|
|
|
|
|
|
var path = $"{$"{Path.DirectorySeparatorChar}files{Path.DirectorySeparatorChar}import{Path.DirectorySeparatorChar}{id}{Path.DirectorySeparatorChar}"}"; |
|
|
|
|
|
|
|
if (!Directory.Exists(physicsPath + path)) |
|
|
|
|
|
|
|
Directory.CreateDirectory(physicsPath + path); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
var filepath = physicsPath + path + file.FileName; |
|
|
|
|
|
|
|
using (var stream = File.Create(filepath)) |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
await file.CopyToAsync(stream); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
string extension = Path.GetExtension(filepath); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
bool isExistError = false; |
|
|
|
|
|
|
|
var id1 = SnowFlakeSingle.instance.getID(); |
|
|
|
|
|
|
|
string errorFileName = path + SnowFlakeSingle.instance.getID() + extension; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
var dt = NPOIHelper.ImportExcel(filepath, "讲师维护"); |
|
|
|
|
|
|
|
if (dt.Columns["Comments"] == null) |
|
|
|
|
|
|
|
dt.Columns.Add("Comments", typeof(string)); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
var fields = new List<string> |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
"讲师分类", |
|
|
|
|
|
|
|
"工号", |
|
|
|
|
|
|
|
"姓名", |
|
|
|
|
|
|
|
"培训机构", |
|
|
|
|
|
|
|
"讲师编号", |
|
|
|
|
|
|
|
"讲师姓名", |
|
|
|
|
|
|
|
"性别", |
|
|
|
|
|
|
|
"邮箱", |
|
|
|
|
|
|
|
"手机号码", |
|
|
|
|
|
|
|
"讲师等级", |
|
|
|
|
|
|
|
"课时费", |
|
|
|
|
|
|
|
"擅长领域", |
|
|
|
|
|
|
|
"备注" |
|
|
|
|
|
|
|
}; |
|
|
|
|
|
|
|
for (int i = 0; i < dt.Rows.Count; i++) |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
var comments = new List<string>(); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
bool isContinue = false; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
fields.ForEach(x => |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
if (!dt.Columns.Contains(x)) |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
comments.Add("未查询到【" + x + "】列！"); |
|
|
|
|
|
|
|
data.ErrorCount++; |
|
|
|
|
|
|
|
dt.Rows[i]["Comments"] = string.Join(";", comments.Select(a => a)); |
|
|
|
|
|
|
|
isExistError = true; |
|
|
|
|
|
|
|
isContinue = true; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
}); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (isContinue) |
|
|
|
|
|
|
|
continue; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
var TeacherType = dt.Rows[i]["讲师分类"].ToString(); |
|
|
|
|
|
|
|
var StaffNo = dt.Rows[i]["工号"].ToString(); |
|
|
|
|
|
|
|
var StaffName = dt.Rows[i]["姓名"].ToString(); |
|
|
|
|
|
|
|
var SchoolName = dt.Rows[i]["培训机构"].ToString(); |
|
|
|
|
|
|
|
var Score = dt.Rows[i]["讲师编号"].ToString(); |
|
|
|
|
|
|
|
var AdjustScore = dt.Rows[i]["讲师姓名"].ToString(); |
|
|
|
|
|
|
|
var ActualScore = dt.Rows[i]["性别"].ToString(); |
|
|
|
|
|
|
|
var IsPass = dt.Rows[i]["邮箱"].ToString(); |
|
|
|
|
|
|
|
//var IsPass = dt.Rows[i]["手机号码"].ToString(); |
|
|
|
|
|
|
|
//var IsPass = dt.Rows[i]["讲师等级"].ToString(); |
|
|
|
|
|
|
|
//var IsPass = dt.Rows[i]["课时费"].ToString(); |
|
|
|
|
|
|
|
//var IsPass = dt.Rows[i]["擅长领域"].ToString(); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (StaffNo.IsNullOrEmpty() && StaffName.IsNullOrEmpty()) |
|
|
|
|
|
|
|
continue; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
var remarkSz = dt.Rows[i]["备注"].ToString(); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
var staff = await Db.Queryable<Ghra_Staff>().Where(x => x.StaffNo == StaffNo && x.StaffName == StaffName).FirstAsync(); |
|
|
|
|
|
|
|
if (staff == null) |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
comments.Add($"未查询到该员工，工号或姓名填写错误！"); |
|
|
|
|
|
|
|
data.ErrorCount++; |
|
|
|
|
|
|
|
dt.Rows[i]["Comments"] = string.Join(";", comments.Select(a => a)); |
|
|
|
|
|
|
|
isExistError = true; |
|
|
|
|
|
|
|
continue; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
var exam = await Db.Queryable<Ghre_Exam>().Where(x => x.Id == MasterId).FirstAsync(); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
//if (ExamDate.IsNullOrEmpty()) |
|
|
|
|
|
|
|
// ExamDate = DateTime.Now.ToString(); |
|
|
|
|
|
|
|
if (Score.IsNullOrEmpty()) |
|
|
|
|
|
|
|
Score = "0"; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
try |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
Convert.ToInt32(Score); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
catch (Exception) |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
comments.Add($"考试分数填写有误！"); |
|
|
|
|
|
|
|
data.ErrorCount++; |
|
|
|
|
|
|
|
dt.Rows[i]["Comments"] = string.Join(";", comments.Select(a => a)); |
|
|
|
|
|
|
|
isExistError = true; |
|
|
|
|
|
|
|
continue; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
try |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
Convert.ToInt32(AdjustScore); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
catch (Exception) |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
comments.Add($"调整分填写有误！"); |
|
|
|
|
|
|
|
data.ErrorCount++; |
|
|
|
|
|
|
|
dt.Rows[i]["Comments"] = string.Join(";", comments.Select(a => a)); |
|
|
|
|
|
|
|
isExistError = true; |
|
|
|
|
|
|
|
continue; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
try |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
Convert.ToInt32(ActualScore); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
catch (Exception) |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
comments.Add($"实操分填写有误！"); |
|
|
|
|
|
|
|
data.ErrorCount++; |
|
|
|
|
|
|
|
dt.Rows[i]["Comments"] = string.Join(";", comments.Select(a => a)); |
|
|
|
|
|
|
|
isExistError = true; |
|
|
|
|
|
|
|
continue; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
//try |
|
|
|
|
|
|
|
//{ |
|
|
|
|
|
|
|
// Convert.ToDateTime(ExamDate); |
|
|
|
|
|
|
|
//} |
|
|
|
|
|
|
|
//catch (Exception) |
|
|
|
|
|
|
|
//{ |
|
|
|
|
|
|
|
// comments.Add($"考试日期填写有误！"); |
|
|
|
|
|
|
|
// data.ErrorCount++; |
|
|
|
|
|
|
|
// dt.Rows[i]["Comments"] = string.Join(";", comments.Select(a => a)); |
|
|
|
|
|
|
|
// isExistError = true; |
|
|
|
|
|
|
|
// continue; |
|
|
|
|
|
|
|
//} |
|
|
|
|
|
|
|
//if (await base.AnyAsync(x => x.CertificateRuleId == rule.Id && x.StaffId == staff.StaffID && x.CourseId == course.Id)) |
|
|
|
|
|
|
|
//{ |
|
|
|
|
|
|
|
// comments.Add($"系统已存在相同证照数据！"); |
|
|
|
|
|
|
|
// data.ErrorCount++; |
|
|
|
|
|
|
|
// dt.Rows[i]["Comments"] = string.Join(";", comments.Select(a => a)); |
|
|
|
|
|
|
|
// isExistError = true; |
|
|
|
|
|
|
|
// continue; |
|
|
|
|
|
|
|
//} |
|
|
|
|
|
|
|
var snap = await Db.Queryable<Ghre_CourseSnap>().FirstAsync(x => x.CourseId == exam.CourseId); |
|
|
|
|
|
|
|
var ExamRecordId = SnowFlakeSingle.Instance.NextId(); |
|
|
|
|
|
|
|
var StudyRecordId = SnowFlakeSingle.Instance.NextId(); |
|
|
|
|
|
|
|
var dict1 = new Dictionary<string, object> |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
{ "Id", StudyRecordId }, |
|
|
|
|
|
|
|
{ "CreateBy", App.User.ID }, |
|
|
|
|
|
|
|
{ "CreateTime", DateTime.Now }, |
|
|
|
|
|
|
|
{ "ExamId", MasterId }, |
|
|
|
|
|
|
|
{ "StaffId", staff.StaffID }, |
|
|
|
|
|
|
|
{ "CourseId", exam.CourseId }, |
|
|
|
|
|
|
|
{ "CourseSnapId", snap?.Id }, |
|
|
|
|
|
|
|
{ "CourseSceneId", exam.CourseSceneId }, |
|
|
|
|
|
|
|
{ "JoinTime", DateTime.Now }, |
|
|
|
|
|
|
|
{ "RemarkSz", "导入讲师维护生成" } |
|
|
|
|
|
|
|
}; |
|
|
|
|
|
|
|
var dict = new Dictionary<string, object> |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
{ "Id", ExamRecordId }, |
|
|
|
|
|
|
|
{ "CreateBy", App.User.ID }, |
|
|
|
|
|
|
|
{ "CreateTime", DateTime.Now }, |
|
|
|
|
|
|
|
{ "ExamId", MasterId }, |
|
|
|
|
|
|
|
{ "StudyRecordId", StudyRecordId }, |
|
|
|
|
|
|
|
{ "StaffId", staff.StaffID }, |
|
|
|
|
|
|
|
//{ "CourseId", exam.CourseId }, |
|
|
|
|
|
|
|
{ "CourseSnapId", snap?.Id }, |
|
|
|
|
|
|
|
{ "Score", Score }, |
|
|
|
|
|
|
|
{ "AdjustScore", Score }, |
|
|
|
|
|
|
|
{ "ActualScore", ActualScore }, |
|
|
|
|
|
|
|
//{ "ExamDate", ExamDate }, |
|
|
|
|
|
|
|
{ "IsPass", IsPass=="是"?true:false }, |
|
|
|
|
|
|
|
{ "ScoreStatus", "HasScore" }, |
|
|
|
|
|
|
|
{ "Source", "ExcelImport" }, |
|
|
|
|
|
|
|
{ "ExamPaperId",exam.ExamPaperId }, |
|
|
|
|
|
|
|
{ "RemarkSz", remarkSz } |
|
|
|
|
|
|
|
}; |
|
|
|
|
|
|
|
try |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
await Db.Insertable(dict1).AS("Ghre_StudyRecord").ExecuteCommandAsync(); |
|
|
|
|
|
|
|
await Db.Insertable(dict).AS("Ghre_ExamRecord").ExecuteCommandAsync(); |
|
|
|
|
|
|
|
data.SuccessCount++; |
|
|
|
|
|
|
|
//data.SuccessCount += list.Count; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
catch (Exception E) |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
comments.Add(E.Message); |
|
|
|
|
|
|
|
data.ErrorCount++; |
|
|
|
|
|
|
|
dt.Rows[i]["Comments"] = string.Join(";", comments.Select(a => a)); |
|
|
|
|
|
|
|
isExistError = true; |
|
|
|
|
|
|
|
continue; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (isExistError) |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
NPOIHelper.ExportExcel(dt, null, "讲师维护", physicsPath + errorFileName); |
|
|
|
|
|
|
|
data.filePath = errorFileName; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
return ServiceResult<ExcelData>.OprateSuccess("导入成功！", data); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
#endregion |
|
|
|
} |
|
|
|
} |
xiaochanghai
6 months ago