570 lines
26 KiB
C#
570 lines
26 KiB
C#
using System;
|
||
using APT.BaseData.Domain.Entities.FM;
|
||
using APT.BaseData.Domain.Entities.OP;
|
||
using APT.BaseData.Domain.IServices.FM;
|
||
using APT.Infrastructure.Api;
|
||
using APT.Infrastructure.Core;
|
||
using APT.Migrations;
|
||
using APT.MS.Domain.Entities.WB;
|
||
using APT.Utility;
|
||
using Microsoft.AspNetCore.Mvc;
|
||
using System.Security.Cryptography;
|
||
using System.Collections.Generic;
|
||
using APT.BaseData.Domain.Enums;
|
||
using System.Linq;
|
||
using APT.BaseData.Domain.Entities;
|
||
using APT.MS.Domain.Enums;
|
||
|
||
namespace APT.SC.WebApi.Controllers.Api.WB
|
||
{
|
||
[Route("api/WB/WBOutsource")]
|
||
public class WBOutsourceController : AuthorizeApiController<T_WB_OUTSOURCE>
|
||
{
|
||
IFMNotificationTaskService NotificationTaskService { get; set; }
|
||
public WBOutsourceController(IFMNotificationTaskService notificationTaskService)
|
||
{
|
||
NotificationTaskService = notificationTaskService;
|
||
}
|
||
/// <summary>
|
||
/// 保存
|
||
/// </summary>
|
||
/// <param name="entity"></param>
|
||
/// <returns></returns>
|
||
[HttpPost, Route("FullUpdate")]
|
||
public JsonActionResult<bool> FullUpdate([FromBody] T_WB_OUTSOURCE entity)
|
||
{
|
||
return SafeExecute(() =>
|
||
{
|
||
if (!APT.Infrastructure.Api.AppContext.CurrentSession.UserID.HasValue)
|
||
{
|
||
throw new Exception("获取登录人员信息失败！");
|
||
}
|
||
if (entity.Nav_Tests == null || !entity.Nav_Tests.Any() || entity.Nav_Tests.Count() < 1)
|
||
{
|
||
throw new Exception("请录入题库！");
|
||
}
|
||
|
||
entity.USER_ID = APT.Infrastructure.Api.AppContext.CurrentSession.UserID.Value;
|
||
entity.CREATE_TIME = DateTime.Now;
|
||
|
||
var videos = entity.Nav_Videos;
|
||
entity.Nav_Videos = null;
|
||
var files = entity.Nav_Files;
|
||
entity.Nav_Files = null;
|
||
var tests = entity.Nav_Tests;
|
||
entity.Nav_Tests = null;
|
||
if (videos != null && videos.Any() && files != null && files.Any())
|
||
{
|
||
var vc = videos.Select(e => !e.IS_DELETED);
|
||
var fc = files.Select(e => !e.IS_DELETED);
|
||
if (vc != null && vc.Count() > 0 && fc != null && fc.Count() > 0)
|
||
throw new Exception("视频和文件不能同时存在！");
|
||
}
|
||
if (videos != null && videos.Any())
|
||
{
|
||
foreach (var item in videos)
|
||
{
|
||
item.Nav_Video = null;
|
||
}
|
||
}
|
||
List<int> listResultD = new List<int>() { 1, 2, 4, 8, 17 };
|
||
int rowIndex = 0;
|
||
|
||
int allScore = 0;
|
||
List<string> listAnswer = null;
|
||
foreach (var item in tests)
|
||
{
|
||
if (item.IS_DELETED)
|
||
{
|
||
continue;
|
||
}
|
||
rowIndex++;
|
||
if (item.ROW_NO == 0)
|
||
{
|
||
item.ROW_NO = rowIndex;
|
||
}
|
||
item.TRAINNAME = entity.NAME;
|
||
allScore += item.SCORE;
|
||
//ANSWER_SHOW
|
||
if (string.IsNullOrEmpty(item.ANSWER_SHOW))
|
||
{
|
||
throw new Exception("请输入行【" + rowIndex + "】的答案");
|
||
}
|
||
|
||
switch (item.TYPE)
|
||
{
|
||
case MS.Domain.Enums.SETestTypeEnum.是非题:
|
||
//if (1 != item.ANSWER && 2 != item.ANSWER)
|
||
//{
|
||
// throw new Exception("行【" + rowIndex + "】的答案输入有误！【是:1 否:2 】");
|
||
//}
|
||
if (item.ANSWER_SHOW.Trim() == "A")
|
||
{
|
||
item.ANSWER = 1;
|
||
}
|
||
else if (item.ANSWER_SHOW.Trim() == "B")
|
||
{
|
||
item.ANSWER = 2;
|
||
}
|
||
else
|
||
{
|
||
throw new Exception("行" + rowIndex + "的答案【" + item.ANSWER_SHOW + "】输入有误！【A/B】");
|
||
//throw new Exception("行【" + rowIndex + "】的答案输入有误！【是:1 否:2 】");
|
||
}
|
||
break;
|
||
case MS.Domain.Enums.SETestTypeEnum.单选题:
|
||
item.ANSWER = 0;
|
||
switch (item.ANSWER_SHOW)
|
||
{
|
||
case "A":
|
||
item.ANSWER = 1;
|
||
break;
|
||
case "B":
|
||
item.ANSWER = 2;
|
||
break;
|
||
case "C":
|
||
item.ANSWER = 4;
|
||
break;
|
||
case "D":
|
||
item.ANSWER = 8;
|
||
break;
|
||
default:
|
||
break;
|
||
}
|
||
if (item.ANSWER == 0)
|
||
{
|
||
throw new Exception("行" + rowIndex + "的答案【" + item.ANSWER_SHOW + "】输入有误！【A/B/C/D】");
|
||
}
|
||
//if (!listResultD.Contains(item.ANSWER))
|
||
//{
|
||
// throw new Exception("行【" + rowIndex + "】的答案输入有误！【A:1, B:2, C:4, D:8】");
|
||
//}
|
||
break;
|
||
case MS.Domain.Enums.SETestTypeEnum.多选题:
|
||
//if (item.ANSWER > 33)
|
||
//{
|
||
// throw new Exception("行【" + rowIndex + "】的答案输入有误！组合【A:1, B:2, C:4, D:8, E:16】相加");
|
||
//}
|
||
item.ANSWER = 0;
|
||
if (item.ANSWER_SHOW.Contains(","))
|
||
{
|
||
listAnswer = item.ANSWER_SHOW.Split(",", StringSplitOptions.RemoveEmptyEntries).ToList();
|
||
foreach (var itemA in listAnswer)
|
||
{
|
||
switch (itemA)
|
||
{
|
||
case "A":
|
||
item.ANSWER += 1;
|
||
break;
|
||
case "B":
|
||
item.ANSWER += 2;
|
||
break;
|
||
case "C":
|
||
item.ANSWER += 4;
|
||
break;
|
||
case "D":
|
||
item.ANSWER += 8;
|
||
break;
|
||
case "E":
|
||
item.ANSWER += 16;
|
||
break;
|
||
default:
|
||
throw new Exception("行" + rowIndex + "的答案【" + item.ANSWER_SHOW + "】输入有误！【A,B,C,D,E】答案用[,]分割");
|
||
break;
|
||
}
|
||
}
|
||
if (item.ANSWER == 1 || item.ANSWER == 2 || item.ANSWER == 4 || item.ANSWER == 8 || item.ANSWER == 16)
|
||
{
|
||
throw new Exception("行" + rowIndex + "的答案【" + item.ANSWER_SHOW + "】输入有误！【A/B/C/D/E】答案用[,]分割，并且不能重复！");
|
||
}
|
||
}
|
||
else
|
||
{
|
||
throw new Exception("行" + rowIndex + "的答案【" + item.ANSWER_SHOW + "】输入有误！【A/B/C/D/E】答案用[,]分割");
|
||
}
|
||
break;
|
||
default:
|
||
break;
|
||
}
|
||
}
|
||
|
||
UnifiedCommit(() =>
|
||
{
|
||
UpdateEntityNoCommit(entity);
|
||
if (files != null && files.Any())
|
||
BantchSaveEntityNoCommit(files);
|
||
if (videos != null && videos.Any())
|
||
BantchSaveEntityNoCommit(videos);
|
||
if (tests != null && tests.Any())
|
||
BantchSaveEntityNoCommit(tests);
|
||
});
|
||
return true;
|
||
});
|
||
}
|
||
|
||
/// <summary>
|
||
/// 获得单条实体数据
|
||
/// </summary>
|
||
/// <param name="filter">过滤实体</param>
|
||
/// <returns></returns>
|
||
[HttpPost, Route("GetSuit")]
|
||
public JsonActionResult<T_WB_OUTSOURCE> GetSuit([FromBody] KeywordFilter filter)
|
||
{
|
||
return SafeExecute(() =>
|
||
{
|
||
var result = GetEntity<T_WB_OUTSOURCE>(null, filter, null);
|
||
if (result != null && result.Nav_Tests != null && result.Nav_Tests.Any())
|
||
{
|
||
foreach (var item in result.Nav_Tests)
|
||
{
|
||
if (item.TYPE == SETestTypeEnum.是非题)
|
||
{
|
||
if (item.ANSWER == 1)
|
||
{
|
||
item.ANSWER_SHOW = "A";
|
||
}
|
||
else
|
||
{
|
||
item.ANSWER_SHOW = "B";
|
||
}
|
||
}
|
||
else if (item.TYPE == SETestTypeEnum.单选题)
|
||
{
|
||
switch (item.ANSWER)
|
||
{
|
||
case 1:
|
||
item.ANSWER_SHOW = "A";
|
||
break;
|
||
case 2:
|
||
item.ANSWER_SHOW = "B";
|
||
break;
|
||
case 4:
|
||
item.ANSWER_SHOW = "C";
|
||
break;
|
||
case 8:
|
||
item.ANSWER_SHOW = "D";
|
||
break;
|
||
default:
|
||
break;
|
||
}
|
||
}
|
||
else //多选
|
||
{
|
||
switch (item.ANSWER)
|
||
{
|
||
case 1:
|
||
item.ANSWER_SHOW = "A";
|
||
break;
|
||
case 2:
|
||
item.ANSWER_SHOW = "B";
|
||
break;
|
||
case 3:
|
||
item.ANSWER_SHOW = "A,B";
|
||
break;
|
||
case 4:
|
||
item.ANSWER_SHOW = "C";
|
||
break;
|
||
case 5:
|
||
item.ANSWER_SHOW = "A,C";
|
||
break;
|
||
case 6:
|
||
item.ANSWER_SHOW = "B,C";
|
||
break;
|
||
case 7:
|
||
item.ANSWER_SHOW = "A,B,C";
|
||
break;
|
||
case 8:
|
||
item.ANSWER_SHOW = "D";
|
||
break;
|
||
case 9:
|
||
item.ANSWER_SHOW = "A,D";
|
||
break;
|
||
case 10:
|
||
item.ANSWER_SHOW = "B,D";
|
||
break;
|
||
case 11:
|
||
item.ANSWER_SHOW = "A,B,D";
|
||
break;
|
||
case 12:
|
||
item.ANSWER_SHOW = "C,D";
|
||
break;
|
||
case 13:
|
||
item.ANSWER_SHOW = "A,C,D";
|
||
break;
|
||
case 14:
|
||
item.ANSWER_SHOW = "B,C,D";
|
||
break;
|
||
case 15:
|
||
item.ANSWER_SHOW = "A,B,C,D";
|
||
break;
|
||
case 16:
|
||
item.ANSWER_SHOW = "E";
|
||
break;
|
||
case 17:
|
||
item.ANSWER_SHOW = "A,E";
|
||
break;
|
||
case 18:
|
||
item.ANSWER_SHOW = "B,E";
|
||
break;
|
||
case 19:
|
||
item.ANSWER_SHOW = "A,B,E";
|
||
break;
|
||
case 20:
|
||
item.ANSWER_SHOW = "C,E";
|
||
break;
|
||
case 21:
|
||
item.ANSWER_SHOW = "A,C,E";
|
||
break;
|
||
case 22:
|
||
item.ANSWER_SHOW = "B,C,E";
|
||
break;
|
||
case 23:
|
||
item.ANSWER_SHOW = "A,B,C,E";
|
||
break;
|
||
case 24:
|
||
item.ANSWER_SHOW = "D,E";
|
||
break;
|
||
case 25:
|
||
item.ANSWER_SHOW = "A,D,E";
|
||
break;
|
||
case 26:
|
||
item.ANSWER_SHOW = "B,D,E";
|
||
break;
|
||
case 27:
|
||
item.ANSWER_SHOW = "A,B,D,E";
|
||
break;
|
||
case 28:
|
||
item.ANSWER_SHOW = "C,D,E";
|
||
break;
|
||
case 29:
|
||
item.ANSWER_SHOW = "A,C,D,E";
|
||
break;
|
||
case 30:
|
||
item.ANSWER_SHOW = "B,C,D,E";
|
||
break;
|
||
case 31:
|
||
item.ANSWER_SHOW = "A,B,C,D,E";
|
||
break;
|
||
default:
|
||
break;
|
||
}
|
||
}
|
||
}
|
||
}
|
||
return result;
|
||
});
|
||
}
|
||
|
||
|
||
///// <summary>
|
||
///// 查询
|
||
///// </summary>
|
||
///// <param name="filter"></param>
|
||
///// <returns></returns>
|
||
//[HttpPost, Route("GetSource")]
|
||
//public JsonActionResult<T_WB_OUTSOURCE> GetSource([FromBody] KeywordFilter filter)
|
||
//{
|
||
// return SafeExecute<T_WB_OUTSOURCE>(() =>
|
||
// {
|
||
// var RECORD_ID = Guid.Empty;
|
||
// try
|
||
// {
|
||
// if (!string.IsNullOrEmpty(filter.Keyword))
|
||
// {
|
||
// RECORD_ID = new Guid(filter.Keyword);
|
||
// }
|
||
// }
|
||
// catch (Exception)
|
||
// {
|
||
// RECORD_ID = Guid.Empty;
|
||
// }
|
||
// if (RECORD_ID == Guid.Empty)
|
||
// {
|
||
// throw new Exception("获取传参有误！");
|
||
// }
|
||
// var record = GetEntity<T_WB_OUTSOURCE_TRAIN_RECORD>(e => e.ID == RECORD_ID && e.Nav_Parent.NAME != null, "Nav_Parent");
|
||
// if (record.Nav_Parent == null)
|
||
// {
|
||
// throw new Exception("获取安全培训指派信息失败！");
|
||
// }
|
||
// var source = GetEntity<T_WB_OUTSOURCE>(e => e.NAME == record.Nav_Parent.NAME && e.ENABLE_STATUS == FMEnableStatusEnum.启用, "Nav_Files.Nav_ImgFile");
|
||
// return source;
|
||
// });
|
||
//}
|
||
|
||
/// <summary>
|
||
/// 查询
|
||
/// 提交 答题路由 WB/WBOutsourceTrainRecord/SavePapers
|
||
/// </summary>
|
||
/// <param name="filter"></param>
|
||
/// <returns></returns>
|
||
[HttpPost, Route("GetSource")]
|
||
public JsonActionResult<T_WB_OUTSOURCE_TRAIN_RECORD_USERS> GetSource([FromBody] KeywordFilter filter)
|
||
{
|
||
return SafeExecute<T_WB_OUTSOURCE_TRAIN_RECORD_USERS>(() =>
|
||
{
|
||
var ORDER_ID = Guid.Empty;
|
||
try
|
||
{
|
||
if (!string.IsNullOrEmpty(filter.Keyword))
|
||
{
|
||
ORDER_ID = new Guid(filter.Keyword);
|
||
}
|
||
}
|
||
catch (Exception)
|
||
{
|
||
ORDER_ID = Guid.Empty;
|
||
}
|
||
if (ORDER_ID == Guid.Empty)
|
||
{
|
||
throw new Exception("获取传参有误！");
|
||
}
|
||
var result = GetEntity<T_WB_OUTSOURCE_TRAIN_RECORD_USERS>(ORDER_ID, "Nav_ListUserPaper.Nav_Test");
|
||
if (result.Nav_ListUserPaper != null && result.Nav_ListUserPaper.Any())
|
||
{
|
||
result.Nav_ListUserPaper = result.Nav_ListUserPaper.OrderBy(e => e.ROW_NO).ToList();
|
||
var listSourceID = result.Nav_ListUserPaper.Select(e => e.SOURCE_ID).Distinct();
|
||
var listSource = GetEntities<T_WB_OUTSOURCE>(e => listSourceID.Contains(e.ID), null, "Nav_Files.Nav_ImgFile");
|
||
foreach (var item in result.Nav_ListUserPaper)
|
||
{
|
||
item.Nav_Source = listSource.First(e => e.ID == item.SOURCE_ID);
|
||
}
|
||
}
|
||
return result;
|
||
});
|
||
}
|
||
|
||
/// <summary>
|
||
/// 交卷
|
||
/// </summary>
|
||
/// <param name="entity"></param>
|
||
/// <returns></returns>
|
||
/// <exception cref="Exception"></exception>
|
||
[HttpPost, Route("SavePapers")]
|
||
public JsonActionResult<bool> SavePapers([FromBody] T_WB_OUTSOURCE_TRAIN_RECORD_USERS entity)
|
||
{
|
||
return SafeExecute(() =>
|
||
{
|
||
if (entity.SCORE.HasValue && entity.SCORE > 0)
|
||
{
|
||
throw new Exception("试卷已完成");
|
||
}
|
||
if (entity.Nav_ListUserPaper == null || entity.Nav_ListUserPaper.Count() == 0)
|
||
{
|
||
int onlineCount = entity.Nav_ListUserPaper.Where(e => e.IS_ONLINE).Count();
|
||
if (onlineCount > 0)
|
||
{
|
||
//有些可能 线上直接看视频 不需要做题
|
||
entity.SCORE = 100;//默认100分
|
||
}
|
||
else
|
||
{
|
||
throw new Exception("试卷不能为空");
|
||
}
|
||
}
|
||
else
|
||
{
|
||
foreach (var item in entity.Nav_ListUserPaper)
|
||
{
|
||
if (item.IS_ONLINE)
|
||
{
|
||
item.IS_WATCH = true;
|
||
}
|
||
}
|
||
|
||
entity.SCORE = 0;
|
||
var listSourceID = entity.Nav_ListUserPaper.Select(e => e.SOURCE_ID).Distinct();
|
||
var AllSCORE = 0;
|
||
foreach (var item in listSourceID)
|
||
{
|
||
AllSCORE += entity.Nav_ListUserPaper.Where(e => e.SOURCE_ID == item).Sum(e => e.SCORE.Value);
|
||
}
|
||
entity.SCORE = AllSCORE / listSourceID.Count();
|
||
}
|
||
|
||
//var orgId = APT.Infrastructure.Api.AppContext.CurrentSession.OrgId;
|
||
//var userID = APT.Infrastructure.Api.AppContext.CurrentSession.UserID;
|
||
//var users = GetEntities<T_WB_OUTSOURCE_TRAIN_RECORD_USERS>(t => t.PARENT_ID == entity.ID, new BaseFilter(orgId));
|
||
//var currUsers = users.Where(t => t.USER_ID == userID);
|
||
//foreach (var user in currUsers)
|
||
//{
|
||
// user.DEAL_STATUS = FOUserShiftStatusEnum.已处理;
|
||
// user.MODIFY_TIME = DateTime.Now;
|
||
//}
|
||
|
||
//var currUser = GetEntity<T_WB_OUTSOURCE_TRAIN_RECORD_USERS>(entity.ID);
|
||
entity.SIGN_STATUS = FOUserShiftStatusEnum.待处理;//FOUserShiftStatusEnum.已处理; 考试 待老师 确认 后 也是需要再次确认
|
||
entity.DEAL_STATUS = ExamStatusEnum.已处理;
|
||
entity.MODIFY_TIME = DateTime.Now;
|
||
T_WB_OUTSOURCE_TRAIN_RECORD Record = null;
|
||
|
||
//#region 如果时间超过了培训结束时间
|
||
////判断是否有别的 考试 变成超期无需处理
|
||
|
||
//#endregion
|
||
|
||
var unSign = GetEntity<T_WB_OUTSOURCE_TRAIN_RECORD_USERS>(e => e.PARENT_ID == entity.PARENT_ID && e.ID != entity.ID && e.DEAL_STATUS == 0);
|
||
//var todoCount = users.Count(t => t.DEAL_STATUS == 0);
|
||
//if (todoCount == 0)
|
||
T_FM_NOTIFICATION_TASK task = null;
|
||
|
||
if (unSign == null || unSign.ID == Guid.Empty)
|
||
{
|
||
Record = GetEntity<T_WB_OUTSOURCE_TRAIN_RECORD>(entity.PARENT_ID, "Nav_Parent.Nav_Project", "Nav_Parent.Nav_User");//, "Nav_Parent.Nav_Project" wyw 这个没必要再加入查询啊
|
||
Record.END_TIME = DateTime.Now;
|
||
if (Record.TRAIN_TYPE.IndexOf("1") > -1)
|
||
{
|
||
Record.ONLINE_END_TIME = Record.END_TIME;
|
||
Record.ONLINE_TOTAL_TIME = (int)Math.Ceiling((Record.ONLINE_END_TIME.Value - Record.ONLINE_START_TIME.Value).TotalHours);
|
||
Record.TOTAL_TIME = Record.ONLINE_TOTAL_TIME;//也加上吧
|
||
}
|
||
Record.STATUS = SETrainNotifyStatus.通知中;// 签到完成;
|
||
if (!Record.Nav_Parent.USER_ID.HasValue)
|
||
{
|
||
throw new Exception("未获取到培训讲师信息，请联系管理员！");
|
||
}
|
||
if (Record.ISEND == false)
|
||
{
|
||
Record.ISEND = true;
|
||
//触发讲师确认
|
||
task = NotificationTaskService.InsertUserNoticeTaskModel(Record.Nav_Parent.Nav_Project.UNIT_NAME + "安全培训记录结果确认", Record.ID, Record.ORG_ID, (Guid)Record.Nav_Parent.USER_ID, Record.Nav_Parent.Nav_User.NAME, DateTime.Now, DateTime.Now.AddDays(7), 1, "WB048");
|
||
}
|
||
}
|
||
|
||
T_FM_NOTIFICATION_TASK finishNotice = null;
|
||
if (entity.TaskID != Guid.Empty)
|
||
finishNotice = NotificationTaskService.GetTaskFinishModel(entity.TaskID);
|
||
|
||
//#region 考试通过才能提交 所以考完直接设置分数 考试通过 可以被选作为 作业监护人等
|
||
|
||
//T_WB_REGISTER_2 LoginReg2 = GetEntity<T_WB_REGISTER_2>(e => e.USERID.HasValue && e.USERID == APT.Infrastructure.Api.AppContext.CurrentSession.UserID);
|
||
//if (LoginReg2 != null)
|
||
//{
|
||
// LoginReg2.SCORE = (double)entity.SCORE;
|
||
//}
|
||
//#endregion
|
||
|
||
entity.SIGN_STATUS = FOUserShiftStatusEnum.已处理;//在线考试 默认签到
|
||
|
||
UnifiedCommit(() =>
|
||
{
|
||
if (entity != null)
|
||
UpdateEntity(entity);
|
||
if (finishNotice != null)
|
||
UpdateEntityNoCommit(finishNotice);
|
||
if (Record != null)
|
||
UpdateEntity(Record);
|
||
//if (currUsers != null)
|
||
// BantchUpdateEntity(currUsers, "DEAL_STATUS", "MODIFY_TIME");
|
||
BantchSaveEntityNoCommit(entity.Nav_ListUserPaper);
|
||
if (task != null)
|
||
UpdateEntity(task);
|
||
//if (LoginReg2 != null)
|
||
// UpdateEntity(LoginReg2);
|
||
});
|
||
return true;
|
||
});
|
||
}
|
||
}
|
||
}
|