|
|
|
|
@ -381,8 +381,6 @@ FROM (SELECT A.*, |
|
|
|
|
for (int i = 0; i < dt.Rows.Count; i++) |
|
|
|
|
{ |
|
|
|
|
var comments = new List<string>(); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
bool isContinue = false; |
|
|
|
|
|
|
|
|
|
fields.ForEach(x => |
|
|
|
|
@ -404,57 +402,124 @@ FROM (SELECT A.*, |
|
|
|
|
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 TeacherNo = dt.Rows[i]["讲师编号"].ToString(); |
|
|
|
|
var TeacherName = dt.Rows[i]["讲师姓名"].ToString(); |
|
|
|
|
var Gender = dt.Rows[i]["性别"].ToString(); |
|
|
|
|
var Email = dt.Rows[i]["邮箱"].ToString(); |
|
|
|
|
var Mobile = dt.Rows[i]["手机号码"].ToString(); |
|
|
|
|
var TeacherLevel = dt.Rows[i]["讲师等级"].ToString(); |
|
|
|
|
var Price = dt.Rows[i]["课时费"].ToString(); |
|
|
|
|
var SkillPoints = dt.Rows[i]["擅长领域"].ToString(); |
|
|
|
|
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(); |
|
|
|
|
var dict = new Dictionary<string, object> |
|
|
|
|
{ |
|
|
|
|
{ "Id", SnowFlakeSingle.Instance.NextId() }, |
|
|
|
|
{ "CreateBy", App.User.ID }, |
|
|
|
|
{ "CreateTime", DateTime.Now }, |
|
|
|
|
{ "RemarkSz", remarkSz } |
|
|
|
|
}; |
|
|
|
|
|
|
|
|
|
if (TeacherType.IsNullOrEmpty()) |
|
|
|
|
continue; |
|
|
|
|
if (TeacherType == "内部") |
|
|
|
|
{ |
|
|
|
|
if (StaffNo.IsNullOrEmpty()) |
|
|
|
|
{ |
|
|
|
|
comments.Add("工号不能为空！"); |
|
|
|
|
data.ErrorCount++; |
|
|
|
|
dt.Rows[i]["Comments"] = string.Join(";", comments.Select(a => a)); |
|
|
|
|
isExistError = true; |
|
|
|
|
continue; |
|
|
|
|
} |
|
|
|
|
if (StaffName.IsNullOrEmpty()) |
|
|
|
|
{ |
|
|
|
|
comments.Add("姓名不能为空！"); |
|
|
|
|
data.ErrorCount++; |
|
|
|
|
dt.Rows[i]["Comments"] = string.Join(";", comments.Select(a => a)); |
|
|
|
|
isExistError = true; |
|
|
|
|
continue; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
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; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
//if (ExamDate.IsNullOrEmpty()) |
|
|
|
|
// ExamDate = DateTime.Now.ToString(); |
|
|
|
|
if (Score.IsNullOrEmpty()) |
|
|
|
|
Score = "0"; |
|
|
|
|
TeacherNo = staff.StaffNo; |
|
|
|
|
TeacherName = staff.StaffName; |
|
|
|
|
Email = staff.Email.ObjToString(); |
|
|
|
|
Mobile = staff.Mobile.ObjToString(); |
|
|
|
|
Gender = staff.Gender; |
|
|
|
|
|
|
|
|
|
try |
|
|
|
|
dict.Add("DeptID", staff.DeptID); |
|
|
|
|
dict.Add("StaffId", staff.StaffID); |
|
|
|
|
dict.Add("TeacherType", "In"); |
|
|
|
|
} |
|
|
|
|
else |
|
|
|
|
{ |
|
|
|
|
Convert.ToInt32(Score); |
|
|
|
|
if (Gender.IsNullOrEmpty()) |
|
|
|
|
Gender = "unknown"; |
|
|
|
|
else |
|
|
|
|
Gender = Gender == "男" ? "Male" : "Female"; |
|
|
|
|
|
|
|
|
|
if (SchoolName.IsNullOrEmpty()) |
|
|
|
|
{ |
|
|
|
|
comments.Add("培训机构不能为空！"); |
|
|
|
|
data.ErrorCount++; |
|
|
|
|
dt.Rows[i]["Comments"] = string.Join(";", comments.Select(a => a)); |
|
|
|
|
isExistError = true; |
|
|
|
|
continue; |
|
|
|
|
} |
|
|
|
|
var school = await Db.Queryable<Ghre_School>().Where(x => x.SchoolName == SchoolName).FirstAsync(); |
|
|
|
|
if (school is null) |
|
|
|
|
{ |
|
|
|
|
comments.Add("无效的培训机构！"); |
|
|
|
|
data.ErrorCount++; |
|
|
|
|
dt.Rows[i]["Comments"] = string.Join(";", comments.Select(a => a)); |
|
|
|
|
isExistError = true; |
|
|
|
|
continue; |
|
|
|
|
} |
|
|
|
|
dict.Add("SchoolId", school.Id); |
|
|
|
|
|
|
|
|
|
if (TeacherNo.IsNullOrEmpty()) |
|
|
|
|
{ |
|
|
|
|
comments.Add("讲师编号不能为空！"); |
|
|
|
|
data.ErrorCount++; |
|
|
|
|
dt.Rows[i]["Comments"] = string.Join(";", comments.Select(a => a)); |
|
|
|
|
isExistError = true; |
|
|
|
|
continue; |
|
|
|
|
} |
|
|
|
|
if (TeacherName.IsNullOrEmpty()) |
|
|
|
|
{ |
|
|
|
|
comments.Add("讲师姓名不能为空！"); |
|
|
|
|
data.ErrorCount++; |
|
|
|
|
dt.Rows[i]["Comments"] = string.Join(";", comments.Select(a => a)); |
|
|
|
|
isExistError = true; |
|
|
|
|
continue; |
|
|
|
|
} |
|
|
|
|
dict.Add("TeacherType", "Out"); |
|
|
|
|
} |
|
|
|
|
catch (Exception) |
|
|
|
|
if (TeacherLevel.IsNullOrEmpty()) |
|
|
|
|
{ |
|
|
|
|
comments.Add($"考试分数填写有误！"); |
|
|
|
|
comments.Add("讲师等级不能为空！"); |
|
|
|
|
data.ErrorCount++; |
|
|
|
|
dt.Rows[i]["Comments"] = string.Join(";", comments.Select(a => a)); |
|
|
|
|
isExistError = true; |
|
|
|
|
continue; |
|
|
|
|
} |
|
|
|
|
try |
|
|
|
|
{ |
|
|
|
|
Convert.ToInt32(AdjustScore); |
|
|
|
|
} |
|
|
|
|
catch (Exception) |
|
|
|
|
|
|
|
|
|
var items = await GetParaList("TrainingTeacherLevel"); |
|
|
|
|
TeacherLevel = items.Where(x => x.ParaDetailName == TeacherLevel).FirstOrDefault()?.ParaDetailNo ?? "In"; |
|
|
|
|
|
|
|
|
|
if (Price.IsNullOrEmpty()) |
|
|
|
|
{ |
|
|
|
|
comments.Add($"调整分填写有误！"); |
|
|
|
|
comments.Add("课时费不能为空！"); |
|
|
|
|
data.ErrorCount++; |
|
|
|
|
dt.Rows[i]["Comments"] = string.Join(";", comments.Select(a => a)); |
|
|
|
|
isExistError = true; |
|
|
|
|
@ -462,76 +527,33 @@ FROM (SELECT A.*, |
|
|
|
|
} |
|
|
|
|
try |
|
|
|
|
{ |
|
|
|
|
Convert.ToInt32(ActualScore); |
|
|
|
|
Convert.ToInt32(Price); |
|
|
|
|
} |
|
|
|
|
catch (Exception) |
|
|
|
|
{ |
|
|
|
|
comments.Add($"实操分填写有误！"); |
|
|
|
|
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 } |
|
|
|
|
}; |
|
|
|
|
|
|
|
|
|
dict.Add("TeacherNo", TeacherNo); |
|
|
|
|
dict.Add("TeacherName", TeacherName); |
|
|
|
|
dict.Add("Email", Email); |
|
|
|
|
dict.Add("Mobile", Mobile); |
|
|
|
|
dict.Add("Gender", Gender); |
|
|
|
|
dict.Add("Price", Price); |
|
|
|
|
dict.Add("TeacherLevel", TeacherLevel); |
|
|
|
|
dict.Add("SkillPoints", SkillPoints); |
|
|
|
|
|
|
|
|
|
if (menuName == "F_TeacherManage") |
|
|
|
|
dict.Add("Status", "Wait"); |
|
|
|
|
else |
|
|
|
|
dict.Add("Status", "Temporary"); |
|
|
|
|
try |
|
|
|
|
{ |
|
|
|
|
await Db.Insertable(dict1).AS("Ghre_StudyRecord").ExecuteCommandAsync(); |
|
|
|
|
await Db.Insertable(dict).AS("Ghre_ExamRecord").ExecuteCommandAsync(); |
|
|
|
|
await Db.Insertable(dict).AS("Ghre_Teacher").ExecuteCommandAsync(); |
|
|
|
|
data.SuccessCount++; |
|
|
|
|
//data.SuccessCount += list.Count; |
|
|
|
|
} |
|
|
|
|
@ -543,15 +565,15 @@ FROM (SELECT A.*, |
|
|
|
|
isExistError = true; |
|
|
|
|
continue; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
if (isExistError) |
|
|
|
|
{ |
|
|
|
|
NPOIHelper.ExportExcel(dt, null, "讲师维护", physicsPath + errorFileName); |
|
|
|
|
data.filePath = errorFileName; |
|
|
|
|
data.filePath = "/Advanced" + errorFileName; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
return ServiceResult<ExcelData>.OprateSuccess("导入成功！", data); |
|
|
|
|
} |
|
|
|
|
#endregion |
|
|
|
|
|
|
|
|
|
} |
xiaochanghai
6 months ago