You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
539 lines
24 KiB
539 lines
24 KiB
namespace Tiobon.Core.Services;
|
|
|
|
/// <summary>
|
|
/// 开班管理 (服务)
|
|
/// </summary>
|
|
public class Ghre_OpenClassServices : BaseServices<Ghre_OpenClass, Ghre_OpenClassDto, InsertGhre_OpenClassInput, EditGhre_OpenClassInput>, IGhre_OpenClassServices
|
|
{
|
|
private readonly IGhre_OpenClassStaffServices _ghre_OpenClassStaffServices;
|
|
private readonly IGhre_OpenClassFeeServices _ghre_OpenClassFeeServices;
|
|
private readonly IGhre_OpenClassScheduleServices _ghre_OpenClassScheduleServices;
|
|
private readonly IBaseRepository<Ghre_OpenClass> _dal;
|
|
public Ghre_OpenClassServices(ICaching caching,
|
|
IBaseRepository<Ghre_OpenClass> dal,
|
|
IGhre_OpenClassStaffServices ghre_OpenClassStaffServices,
|
|
IGhre_OpenClassFeeServices ghre_OpenClassFeeServices,
|
|
IGhre_OpenClassScheduleServices ghre_OpenClassScheduleServices)
|
|
{
|
|
this._dal = dal;
|
|
base.BaseDal = dal;
|
|
base._caching = caching;
|
|
_ghre_OpenClassStaffServices = ghre_OpenClassStaffServices;
|
|
_ghre_OpenClassFeeServices = ghre_OpenClassFeeServices;
|
|
_ghre_OpenClassScheduleServices = ghre_OpenClassScheduleServices;
|
|
}
|
|
|
|
public override async Task<ServicePageResult<Ghre_OpenClassDto>> QueryFilterPage(QueryBody filter, string condition, bool? IsEnable = true)
|
|
{
|
|
|
|
if (filter.jsonParam != null)
|
|
foreach (JProperty jProperty in filter.jsonParam.Properties())
|
|
{
|
|
var name = jProperty.Name;
|
|
var value = jProperty.Value.ToString();
|
|
if (name == "StartEndTime")
|
|
{
|
|
var jsonParam = JsonHelper.JsonToObj<JsonParam>(value);
|
|
|
|
if (jsonParam.columnValue != null)
|
|
{
|
|
var ids1 = JsonHelper.JsonToObj<List<string>>(jsonParam.columnValue.ToString());
|
|
|
|
condition += $" AND ((StartTime>='{ids1[0]} 00:00:00' AND StartTime<='{ids1[1]} 23:59:59')";
|
|
condition += $" OR (EndTime>='{ids1[0]} 00:00:00' AND EndTime<='{ids1[1]} 23:59:59'))";
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
var result = await base.QueryFilterPage(filter, condition, IsEnable);
|
|
|
|
for (int i = 0; i < result.result.DT_TableDataT1.Count; i++)
|
|
{
|
|
var DT_TableDataT1 = result.result.DT_TableDataT1[i];
|
|
|
|
DT_TableDataT1.OpenClassType = await GetParaLabel("TrainingOpenClassType", result.result.DT_TableDataT1[i].OpenClassType);
|
|
DT_TableDataT1.OpenClassWay = await GetParaLabel("TrainingOpenClassWay", result.result.DT_TableDataT1[i].OpenClassWay);
|
|
DT_TableDataT1.ScoringMethod = await GetParaLabel("ScoreMethod", result.result.DT_TableDataT1[i].ScoringMethod);
|
|
|
|
if (DT_TableDataT1.LinkType == "Course")
|
|
DT_TableDataT1.CourseOrSceneName = (await Db.Queryable<Ghre_Course>().FirstAsync(x => x.Id == DT_TableDataT1.LinkId))?.CourseName;
|
|
else
|
|
DT_TableDataT1.CourseOrSceneName = (await Db.Queryable<Ghre_CourseScene>().FirstAsync(x => x.Id == DT_TableDataT1.LinkId))?.SceneName;
|
|
|
|
if (DT_TableDataT1.StartTime != null && DT_TableDataT1.EndTime != null)
|
|
DT_TableDataT1.StartEndTime1 = $"{DateTimeHelper.ConvertToMiniuteString(DT_TableDataT1.StartTime)}~{DateTimeHelper.ConvertToMiniuteString(DT_TableDataT1.EndTime)}";
|
|
|
|
if (DT_TableDataT1.RegisterStartTime != null && DT_TableDataT1.RegisterEndTime != null)
|
|
DT_TableDataT1.RegisterStartEndTime1 = $"{DateTimeHelper.ConvertToMiniuteString(DT_TableDataT1.RegisterStartTime)}~{DateTimeHelper.ConvertToMiniuteString(DT_TableDataT1.RegisterEndTime)}";
|
|
|
|
if (DT_TableDataT1.ExamStartTime != null && DT_TableDataT1.ExamEndTime != null)
|
|
DT_TableDataT1.ExamStartEndTime1 = $"{DateTimeHelper.ConvertToMiniuteString(DT_TableDataT1.ExamStartTime)}~{DateTimeHelper.ConvertToMiniuteString(DT_TableDataT1.ExamEndTime)}";
|
|
|
|
if (DT_TableDataT1.ExamPaperId != null)
|
|
DT_TableDataT1.ExamPaperName = (await Db.Queryable<Ghre_ExamPaper>().FirstAsync(x => x.Id == DT_TableDataT1.ExamPaperId))?.PaperName;
|
|
|
|
|
|
if (DT_TableDataT1.ManagerId != null)
|
|
DT_TableDataT1.ManagerName = (await Db.Queryable<Ghra_Staff>().FirstAsync(x => x.StaffID == DT_TableDataT1.ManagerId))?.StaffName;
|
|
|
|
if (DT_TableDataT1.TeacherId != null)
|
|
DT_TableDataT1.TeacherName = (await Db.Queryable<Ghre_Teacher>().FirstAsync(x => x.Id == DT_TableDataT1.TeacherId))?.TeacherName;
|
|
|
|
result.result.DT_TableDataT1[i] = DT_TableDataT1;
|
|
}
|
|
return result;
|
|
}
|
|
|
|
public override async Task<long> Add(InsertGhre_OpenClassInput entity)
|
|
{
|
|
entity.LinkId = entity.LinkType == "Course" ? entity.CourseId : entity.CourseSceneId;
|
|
entity.Status = "Temporary";
|
|
|
|
var prefixTemp = string.Empty;
|
|
if (entity.LinkType == "Course")
|
|
prefixTemp = (await Db.Queryable<Ghre_Course>().FirstAsync(x => x.Id == entity.CourseId))?.CourseNo;
|
|
else
|
|
prefixTemp = (await Db.Queryable<Ghre_CourseScene>().FirstAsync(x => x.Id == entity.CourseSceneId))?.SceneNo;
|
|
|
|
if (entity.StartEndTime.Count == 2)
|
|
{
|
|
entity.StartTime = entity.StartEndTime[0];
|
|
entity.EndTime = entity.StartEndTime[1];
|
|
}
|
|
if (entity.RegisterStartEndTime.Count == 2)
|
|
{
|
|
entity.RegisterStartTime = entity.RegisterStartEndTime[0];
|
|
entity.RegisterEndTime = entity.RegisterStartEndTime[1];
|
|
}
|
|
if (entity.ExamStartEndTime.Count == 2)
|
|
{
|
|
entity.ExamStartTime = entity.ExamStartEndTime[0];
|
|
entity.ExamEndTime = entity.ExamStartEndTime[1];
|
|
}
|
|
|
|
|
|
prefixTemp = prefixTemp + "K";
|
|
entity.OpenClassNo = await GenerateContinuousSequence("Ghre_OpenClass", "OpenClassNo", prefixTemp, prefixTemp.Length + 4, 4);
|
|
var result = await base.Add(entity);
|
|
|
|
if (entity.Schedules != null && entity.Schedules.Any())
|
|
{
|
|
entity.Schedules.ForEach(x =>
|
|
{
|
|
x.OpenClassId = result;
|
|
if (x.StartEndTime.Count == 2)
|
|
{
|
|
x.StartTime = x.StartEndTime[0];
|
|
x.EndTime = x.StartEndTime[1];
|
|
}
|
|
});
|
|
await _ghre_OpenClassScheduleServices.Add(entity.Schedules);
|
|
}
|
|
|
|
if (entity.Attachments != null && entity.Attachments.Any())
|
|
{
|
|
var paths = entity.Attachments.Select(x => x.RelativePath.Replace("/Advanced", null)).ToList();
|
|
await Db.Updateable<Ghre_Attachment>()
|
|
.SetColumns(it => new Ghre_Attachment() { TableName = result.ObjToString(), AttachmentGroupID = 1 })
|
|
.Where(it => paths.Contains(it.RelativePath))
|
|
.ExecuteCommandAsync();
|
|
}
|
|
return result;
|
|
}
|
|
|
|
public override async Task<bool> Update(long Id, EditGhre_OpenClassInput entity)
|
|
{
|
|
|
|
entity.LinkId = entity.LinkType == "Course" ? entity.CourseId : entity.CourseSceneId;
|
|
|
|
if (entity.StartEndTime.Count == 2)
|
|
{
|
|
entity.StartTime = entity.StartEndTime[0];
|
|
entity.EndTime = entity.StartEndTime[1];
|
|
}
|
|
if (entity.RegisterStartEndTime.Count == 2)
|
|
{
|
|
entity.RegisterStartTime = entity.RegisterStartEndTime[0];
|
|
entity.RegisterEndTime = entity.RegisterStartEndTime[1];
|
|
}
|
|
if (entity.ExamStartEndTime.Count == 2)
|
|
{
|
|
entity.ExamStartTime = entity.ExamStartEndTime[0];
|
|
entity.ExamEndTime = entity.ExamStartEndTime[1];
|
|
}
|
|
await _ghre_OpenClassScheduleServices.Delete(x => x.OpenClassId == Id);
|
|
if (entity.Schedules != null && entity.Schedules.Any())
|
|
{
|
|
entity.Schedules.ForEach(x => x.OpenClassId = Id);
|
|
|
|
await _ghre_OpenClassScheduleServices.Add(entity.Schedules);
|
|
}
|
|
await Db.Updateable<Ghre_Attachment>()
|
|
.SetColumns(it => new Ghre_Attachment() { TableName = null, AttachmentGroupID = null })
|
|
.Where(it => it.TableName == Id.ObjToString() && it.AttachmentGroupID == 1)
|
|
.ExecuteCommandAsync();
|
|
|
|
if (entity.Attachments != null && entity.Attachments.Any())
|
|
{
|
|
var paths = entity.Attachments.Select(x => x.RelativePath.Replace("/Advanced", null)).ToList();
|
|
await Db.Updateable<Ghre_Attachment>()
|
|
.SetColumns(it => new Ghre_Attachment() { TableName = Id.ObjToString(), AttachmentGroupID = 1 })
|
|
.Where(it => paths.Contains(it.RelativePath))
|
|
.ExecuteCommandAsync();
|
|
}
|
|
var result = await base.Update(Id, entity, null, ["Status"]);
|
|
|
|
return result;
|
|
}
|
|
|
|
|
|
public override async Task<ServiceFormResult<Ghre_OpenClassDto>> QueryForm(QueryForm body)
|
|
{
|
|
var result = await base.QueryForm(body);
|
|
if (result.result.DT_TableDataT1.Any())
|
|
{
|
|
if (result.result.DT_TableDataT1[0].LinkType == "Course")
|
|
result.result.DT_TableDataT1[0].CourseId = result.result.DT_TableDataT1[0].LinkId;
|
|
else
|
|
result.result.DT_TableDataT1[0].CourseSceneId = result.result.DT_TableDataT1[0].LinkId;
|
|
|
|
result.result.DT_TableDataT1[0].StartEndTime.Add(result.result.DT_TableDataT1[0].StartTime);
|
|
result.result.DT_TableDataT1[0].StartEndTime.Add(result.result.DT_TableDataT1[0].EndTime);
|
|
|
|
result.result.DT_TableDataT1[0].RegisterStartEndTime.Add(result.result.DT_TableDataT1[0].RegisterStartTime);
|
|
result.result.DT_TableDataT1[0].RegisterStartEndTime.Add(result.result.DT_TableDataT1[0].RegisterEndTime);
|
|
|
|
result.result.DT_TableDataT1[0].ExamStartEndTime.Add(result.result.DT_TableDataT1[0].ExamStartTime);
|
|
result.result.DT_TableDataT1[0].ExamStartEndTime.Add(result.result.DT_TableDataT1[0].ExamEndTime);
|
|
result.result.DT_TableDataT1[0].Schedules = await _ghre_OpenClassScheduleServices.QueryDto(x => x.OpenClassId == body.id);
|
|
|
|
result.result.DT_TableDataT1[0].Attachments = await Db.Queryable<Ghre_Attachment>().Where(x => x.TableName == body.id.ObjToString() && x.AttachmentGroupID == 1).ToListAsync();
|
|
}
|
|
return result;
|
|
}
|
|
|
|
#region 学员
|
|
public async Task<ServiceResult<List<Ghre_OpenClassStaffDto>>> QueryStaff(long Id)
|
|
{
|
|
var result = await _ghre_OpenClassStaffServices.QueryFilterPage(new QueryBody(), $"OpenClassId='{Id}'");
|
|
return ServiceResult<List<Ghre_OpenClassStaffDto>>.OprateSuccess("查询成功!", result.result.DT_TableDataT1);
|
|
}
|
|
|
|
public async Task<ServiceResult> InsertStaff(long Id, List<int> staffIds)
|
|
{
|
|
var staffIds1 = await Db.Queryable<Ghre_OpenClassStaff>().Where(x => x.OpenClassId == Id).Select(s => s.StaffId).ToListAsync();
|
|
var inserts = staffIds.Where(x => !staffIds1.Contains(x))
|
|
.Select(x => new InsertGhre_OpenClassStaffInput()
|
|
{
|
|
StaffId = x,
|
|
OpenClassId = Id
|
|
}).Distinct().ToList();
|
|
await _ghre_OpenClassStaffServices.Add(inserts);
|
|
return ServiceResult.OprateSuccess();
|
|
}
|
|
|
|
public async Task<ServiceResult> DeleteStaff(long Id, List<int> staffIds)
|
|
{
|
|
await Db.Updateable<Ghre_OpenClassStaff>()
|
|
.SetColumns(it => new Ghre_OpenClassStaff() { IsEnable = 0 })
|
|
.Where(it => it.StaffId != null && it.OpenClassId == Id && staffIds.Contains(it.StaffId.Value))
|
|
.ExecuteCommandAsync();
|
|
return ServiceResult.OprateSuccess();
|
|
}
|
|
public async Task<ServiceResult<ExcelData>> ExportStaff(long Id)
|
|
{
|
|
var result1 = await _ghre_OpenClassStaffServices.QueryFilterPage(new QueryBody(), $"OpenClassId='{Id}'");
|
|
var result = new ExcelData();
|
|
result.fileName = $"开班学员{DateTimeHelper.ConvertToSecondString1(DateTime.Now)}.xlsx";
|
|
var fieldDescs = new Dictionary<string, string>
|
|
{
|
|
{ "StaffNo", "工号" },
|
|
{ "StaffName", "姓名" },
|
|
{ "DeptName", "部门" },
|
|
{ "TitleName", "岗位" },
|
|
{ "Indate", "入职日期" },
|
|
{ "Email", "邮箱" },
|
|
{ "Source", "数据来源" }
|
|
};
|
|
var dt = _ghre_OpenClassStaffServices.ToDataTable1(result1.result.DT_TableDataT1, fieldDescs, null);
|
|
// 获取所有列名
|
|
var dtColumns = dt.Columns;
|
|
|
|
var id = SnowFlakeSingle.instance.getID();
|
|
var physicsPath = $"{Environment.CurrentDirectory}{Path.DirectorySeparatorChar}wwwroot";
|
|
var path = $"{$"{Path.DirectorySeparatorChar}files{Path.DirectorySeparatorChar}export{Path.DirectorySeparatorChar}{id}{Path.DirectorySeparatorChar}"}";
|
|
if (!Directory.Exists(physicsPath + path))
|
|
Directory.CreateDirectory(physicsPath + path);
|
|
|
|
path = path + result.fileName;
|
|
NPOIHelper.ExportExcel(dt, "开班学员", "sheet1", physicsPath + path);
|
|
|
|
result.filePath = "/Advanced" + path;
|
|
return ServiceResult<ExcelData>.OprateSuccess("导出成功", result);
|
|
}
|
|
#endregion
|
|
|
|
#region 费用
|
|
public async Task<ServiceResult<List<Ghre_OpenClassFeeDto>>> QueryGroupFee(long Id)
|
|
{
|
|
var result = await _ghre_OpenClassFeeServices.QueryFilterPage(new QueryBody(), $"OpenClassId='{Id}' AND StaffId IS NULL");
|
|
return ServiceResult<List<Ghre_OpenClassFeeDto>>.OprateSuccess("查询成功!", result.result.DT_TableDataT1);
|
|
}
|
|
public async Task<ServiceResult<List<Ghre_OpenClassFeeDto>>> QueryPersonalFee(long Id)
|
|
{
|
|
var result = await _ghre_OpenClassFeeServices.QueryFilterPage(new QueryBody(), $"OpenClassId='{Id}' AND StaffId IS NOT NULL");
|
|
return ServiceResult<List<Ghre_OpenClassFeeDto>>.OprateSuccess("查询成功!", result.result.DT_TableDataT1);
|
|
}
|
|
|
|
|
|
public async Task<ServiceResult> InsertFee(long Id, InsertGhre_OpenClassFeeInput fee)
|
|
{
|
|
fee.OpenClassId = Id;
|
|
await _ghre_OpenClassFeeServices.Add(fee);
|
|
return ServiceResult.OprateSuccess();
|
|
}
|
|
|
|
public async Task<ServiceResult> DeleteFee(List<long> feeIds)
|
|
{
|
|
await Db.Updateable<Ghre_OpenClassFee>()
|
|
.SetColumns(it => new Ghre_OpenClassFee() { IsEnable = 0 })
|
|
.Where(it => feeIds.Contains(it.Id))
|
|
.ExecuteCommandAsync();
|
|
return ServiceResult.OprateSuccess();
|
|
}
|
|
#endregion
|
|
|
|
#region 总结
|
|
|
|
public async Task<ServiceResult<Ghre_OpenClassDto>> QuerySummary(long Id)
|
|
{
|
|
var result = await base.QueryById(Id);
|
|
|
|
var result1 = new Ghre_OpenClassDto();
|
|
result1.Summary = result.Summary;
|
|
result1.Attachments = await Db.Queryable<Ghre_Attachment>().Where(x => x.TableName == Id.ObjToString() && x.AttachmentGroupID == 2).ToListAsync();
|
|
return ServiceResult<Ghre_OpenClassDto>.OprateSuccess("查询成功!", result1);
|
|
}
|
|
public async Task<ServiceResult> InsertSummary(long Id, InsertGhre_OpenClassInput entity)
|
|
{
|
|
|
|
await Db.Updateable<Ghre_OpenClass>()
|
|
.SetColumns(it => new Ghre_OpenClass() { Summary = entity.Summary })
|
|
.Where(it => it.Id == Id)
|
|
.ExecuteCommandAsync();
|
|
await Db.Updateable<Ghre_Attachment>()
|
|
.SetColumns(it => new Ghre_Attachment() { TableName = null, AttachmentGroupID = null })
|
|
.Where(it => it.TableName == Id.ObjToString() && it.AttachmentGroupID == 2)
|
|
.ExecuteCommandAsync();
|
|
|
|
if (entity.Attachments != null && entity.Attachments.Any())
|
|
{
|
|
var paths = entity.Attachments.Select(x => x.RelativePath.Replace("/Advanced", null)).ToList();
|
|
await Db.Updateable<Ghre_Attachment>()
|
|
.SetColumns(it => new Ghre_Attachment() { TableName = Id.ObjToString(), AttachmentGroupID = 2 })
|
|
.Where(it => paths.Contains(it.RelativePath))
|
|
.ExecuteCommandAsync();
|
|
}
|
|
return ServiceResult.OprateSuccess();
|
|
}
|
|
#endregion
|
|
|
|
#region 修改状态
|
|
[UseTran]
|
|
public async Task<ServiceResult> UpdateStatus(List<long> ids, string status, string source = null)
|
|
{
|
|
|
|
switch (source)
|
|
{
|
|
case "TransferPublished":
|
|
|
|
#region 转入开课,开班自动产生考试数据
|
|
var list = await Query(x => ids.Contains(x.Id));
|
|
for (int i = 0; i < list.Count; i++)
|
|
{
|
|
var entity = list[i];
|
|
|
|
if (entity.ExamId.IsNullOrEmpty())
|
|
{
|
|
var exam = new Ghre_Exam()
|
|
{
|
|
ExamNo = entity.OpenClassNo,
|
|
ExamName = entity.OpenClassName,
|
|
UseDefaultCoverImage = true,
|
|
DateType = "ExamDate",
|
|
BeginTime = entity.ExamStartTime,
|
|
EndTime = entity.ExamEndTime,
|
|
ExamMode = "Online",
|
|
IsLinkOpenClass = true,
|
|
Status = "Released",
|
|
LinkType = entity.LinkType == "Course" ? "CourseId" : "CourseSceneId",
|
|
CourseId = entity.LinkType == "Course" ? entity.LinkId : null,
|
|
CourseSceneId = entity.LinkType == "CourseScene" ? entity.LinkId : null,
|
|
ExamPaperId = entity.ExamPaperId,
|
|
OpenClassId = entity.Id,
|
|
Source = "OpenClass",
|
|
IsRequireStudy = entity.IsRequireStudy,
|
|
PlanId = entity.PlanId,
|
|
OnlineScorePercentage = entity.OnlineScorePercentage,
|
|
OfflineScorePercentage = entity.OfflineScorePercentage,
|
|
ScoreRule = entity.ScoreRule,
|
|
StudyFinishedRule = entity.StudyFinishedRule,
|
|
IsViewResult = entity.IsViewResult,
|
|
IsAfterViewResultRetake = entity.IsAfterViewResultRetake
|
|
};
|
|
var examId = await Db.Insertable(exam).ExecuteReturnSnowflakeIdAsync();
|
|
|
|
await Db.Updateable<Ghre_OpenClass>()
|
|
.SetColumns(it => new Ghre_OpenClass() { Status = status, ExamId = examId })
|
|
.Where(it => it.Id == entity.Id)
|
|
.ExecuteCommandAsync();
|
|
}
|
|
else
|
|
{
|
|
await Db.Updateable<Ghre_Exam>()
|
|
.SetColumns(it => new Ghre_Exam()
|
|
{
|
|
ExamNo = entity.OpenClassNo,
|
|
ExamName = entity.OpenClassName,
|
|
BeginTime = entity.ExamStartTime,
|
|
EndTime = entity.ExamEndTime,
|
|
LinkType = entity.LinkType == "Course" ? "CourseId" : "CourseSceneId",
|
|
CourseId = entity.LinkType == "Course" ? entity.LinkId : null,
|
|
CourseSceneId = entity.LinkType == "CourseScene" ? entity.LinkId : null,
|
|
ExamPaperId = entity.ExamPaperId
|
|
})
|
|
.Where(it => it.Id == entity.ExamId)
|
|
.ExecuteCommandAsync();
|
|
|
|
await Db.Updateable<Ghre_OpenClass>()
|
|
.SetColumns(it => new Ghre_OpenClass() { Status = status })
|
|
.Where(it => it.Id == entity.Id)
|
|
.ExecuteCommandAsync();
|
|
}
|
|
}
|
|
#endregion
|
|
|
|
break;
|
|
default:
|
|
await Db.Updateable<Ghre_OpenClass>()
|
|
.SetColumns(it => new Ghre_OpenClass() { Status = status })
|
|
.Where(it => ids.Contains(it.Id))
|
|
.ExecuteCommandAsync();
|
|
break;
|
|
}
|
|
|
|
|
|
return ServiceResult.OprateSuccess();
|
|
}
|
|
#endregion
|
|
|
|
#region 成绩
|
|
|
|
public async Task<ServiceResult<List<Ghre_OpenClassScore>>> QueryScore(long Id)
|
|
{
|
|
var sql = @$"SELECT A.Id,
|
|
C.StaffNo,
|
|
C.StaffName,
|
|
D.DeptName,
|
|
A.Score,
|
|
A.AdjustScore,
|
|
A.IsPass,
|
|
A.FinallyIsPass,
|
|
A.RetakeTimes,
|
|
A.Comment
|
|
FROM Ghre_ExamRecord A
|
|
JOIN Ghre_Exam B ON A.ExamId = B.Id
|
|
LEFT JOIN Ghra_Staff C ON A.StaffId = C.StaffID
|
|
LEFT JOIN Ghro_Dept D ON C.DeptID = D.DeptID
|
|
WHERE B.OpenClassId = '{Id}'";
|
|
var entitys = await Db.Ado.SqlQueryAsync<Ghre_OpenClassScore>(sql);
|
|
|
|
entitys.ForEach(it =>
|
|
{
|
|
it.IsPassLabel = it.IsPass == true ? "合格" : "不合格";
|
|
it.FinallyIsPassLabel = it.FinallyIsPass == true ? "合格" : "不合格";
|
|
});
|
|
|
|
return ServiceResult<List<Ghre_OpenClassScore>>.OprateSuccess("查询成功!", entitys);
|
|
}
|
|
#endregion
|
|
|
|
#region 报名
|
|
/// <summary>
|
|
/// 报名
|
|
/// </summary>
|
|
/// <param name="Id">开班ID</param>
|
|
/// <returns></returns>
|
|
public async Task<ServiceResult> CheckIn(long Id)
|
|
{
|
|
if (!await base.AnyAsync(x => x.Id == Id))
|
|
return ServiceResult.OprateSuccess("无效的开班ID!");
|
|
if (await Db.Queryable<Ghre_OpenClassStaff>().Where(x => x.StaffId == App.User.StaffId && x.OpenClassId == Id).AnyAsync())
|
|
return ServiceResult.OprateSuccess("已报名,请勿重复提交!");
|
|
|
|
var staff = new Ghre_OpenClassStaff()
|
|
{
|
|
StaffId = App.User.StaffId,
|
|
OpenClassId = Id,
|
|
Source = "CheckIn"
|
|
};
|
|
await Db.Insertable(staff).ExecuteReturnSnowflakeIdAsync();
|
|
return ServiceResult.OprateSuccess("报名成功!");
|
|
}
|
|
#endregion
|
|
|
|
#region 课表
|
|
|
|
public async Task<ServiceResult<Ghre_OpenClassSchedule1>> QuerySchedule(long Id)
|
|
{
|
|
var data = new Ghre_OpenClassSchedule1();
|
|
|
|
var entity = await base.QueryById(Id);
|
|
if (entity.LinkType == "CourseScene")
|
|
{
|
|
|
|
data.SceneName = await Db.Queryable<Ghre_CourseScene>().Where(x => x.Id == entity.LinkId).Select(x => x.SceneName).FirstAsync();
|
|
|
|
var sql = @$"SELECT A.Id,
|
|
A.Address,
|
|
A.StartTime,
|
|
A.EndTime,
|
|
A.TeacherId,
|
|
A.CourseId,
|
|
B.CourseName
|
|
FROM Ghre_OpenClassSchedule A LEFT JOIN Ghre_Course B ON A.CourseId = B.Id
|
|
WHERE A.OpenClassId = '{Id}' AND A.IsEnable = 1";
|
|
data.Details = await Db.Ado.SqlQueryAsync<Ghre_OpenClassScheduleDeatil>(sql);
|
|
|
|
}
|
|
else
|
|
{
|
|
var detail = new Ghre_OpenClassScheduleDeatil()
|
|
{
|
|
Address = entity.Address,
|
|
StartTime = entity.StartTime,
|
|
EndTime = entity.EndTime,
|
|
CourseId = entity.LinkId,
|
|
};
|
|
detail.CourseName = await Db.Queryable<Ghre_Course>().Where(x => x.Id == entity.LinkId).Select(x => x.CourseName).FirstAsync();
|
|
|
|
data.Details.Add(detail);
|
|
}
|
|
|
|
data.Details.ForEach(d =>
|
|
{
|
|
d.Time = DateTimeHelper.ConvertToMiniuteString(d.StartTime) + " ~ " + DateTimeHelper.ConvertToMiniuteString(d.EndTime);
|
|
});
|
|
//entitys.ForEach(it =>
|
|
//{
|
|
// it.IsPassLabel = it.IsPass == true ? "合格" : "不合格";
|
|
// it.FinallyIsPassLabel = it.FinallyIsPass == true ? "合格" : "不合格";
|
|
//});
|
|
|
|
return ServiceResult<Ghre_OpenClassSchedule1>.OprateSuccess("查询成功!", data);
|
|
}
|
|
#endregion
|
|
|
|
|
|
} |