lpf/CNCEC_SUBQHSE_WUHUAN
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

20211207 新增与博晟培训考试对接写入数据接口以及页面数据呈现

Browse Source
This commit is contained in:
杨红卫
2021-12-07 16:34:32 +08:00
parent 3d3e34606e
commit 899a39776a
39 changed files with 8672 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files
SGGL/BLL/API/APIDoorServerService.cs
+18 -8
View File
@@ -20,18 +20,28 @@ namespace BLL
using (Model.SGGLDB db = new Model.SGGLDB(Funs.ConnString))
{
int maxId = 0;
string name = string.Empty;
var getPersonByIdCard = db.SitePerson_Person.Where(x => x.IdentityCard == idCard).OrderByDescending(x=>x.InTime).FirstOrDefault();
if (getPersonByIdCard != null)
{
name = getPersonByIdCard.PersonName;
projectId = getPersonByIdCard.ProjectId;
}
else
{
var getPerson = db.SitePerson_Person.FirstOrDefault(x => x.IdentityCard == idCard && x.ProjectId == projectId);
if (getPerson != null)
{
name = getPerson.PersonName;
}
}
var getmax = db.T_d_facerecord.Where(x => x.ProjectId == projectId && x.RoleID == Intype).Select(x => x.ID);
if (getmax.Count() > 0)
{
maxId = getmax.Max() + 1;
}
string name = string.Empty;
var getPerson = db.SitePerson_Person.FirstOrDefault(x => x.IdentityCard == idCard && x.ProjectId ==projectId);
if (getPerson != null)
{
name = getPerson.PersonName;
}
Model.T_d_facerecord newFacerecord = new Model.T_d_facerecord()
{
NewID = SQLHelper.GetNewID(),
@@ -44,9 +54,9 @@ namespace BLL
RecordDes = Intype,
InOrOut = (isIn == 1 ? "进门" : "出门"),
};
db.T_d_facerecord.InsertOnSubmit(newFacerecord);
db.SubmitChanges();
///// 根据出入记录 写入考勤记录
Model.t_d_facerecordItem facerecord = new Model.t_d_facerecordItem
{
SGGL/BLL/BLL.csproj
+2
View File
@@ -163,6 +163,7 @@
<Compile Include="BaseInfo\UnitTypeService.cs" />
<Compile Include="BaseInfo\WorkPostService.cs" />
<Compile Include="BaseInfo\WorkStageService.cs" />
<Compile Include="BoSheng\BOSHENGService.cs" />
<Compile Include="Common\AttachFileService.cs" />
<Compile Include="Common\CodeRecordsService.cs" />
<Compile Include="Common\CommonService.cs" />
@@ -707,6 +708,7 @@
<Compile Include="TestRun\ProduceTestRun\TestRunRecordService.cs" />
<Compile Include="TestRun\ProduceTestRun\TestRunReportService.cs" />
<Compile Include="TestRun\TestRunService.cs" />
<Compile Include="BoSheng\BOSHENGMonitorService.cs" />
<Compile Include="WebService\MCSWebService.cs" />
<Compile Include="WebService\CNCECHSSEWebService.cs" />
<Compile Include="WebService\CNCECHSSEMonitorService.cs" />
SGGL/BLL/BoSheng/BOSHENGMonitorService.cs
+639
View File
@@ -0,0 +1,639 @@
using Newtonsoft.Json.Linq;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Timers;
namespace BLL
{
public class BOSHENGMonitorService
{
#region 启动监视器 系统启动5分钟
/// <summary>
/// 监视组件
/// </summary>
private static Timer messageTimer;
/// <summary>
/// 启动监视器,不一定能成功，根据系统设置决定对监视器执行的操作 系统启动5分钟
/// </summary>
public static void StartMonitor()
{
int adTimeJ = 120;
if (messageTimer != null)
{
messageTimer.Stop();
messageTimer.Dispose();
messageTimer = null;
}
if (adTimeJ > 0)
{
messageTimer = new Timer
{
AutoReset = true
};
messageTimer.Elapsed += new ElapsedEventHandler(AddData);
messageTimer.Interval = 1000 * 60 * adTimeJ;// 60000 * adTimeJ;
messageTimer.Start();
}
}
/// <summary>
/// 流程确认 定时执行 系统启动5分钟
/// </summary>
/// <param name="sender">Timer组件</param>
/// <param name="e">事件参数</param>
private static void AddData(object sender, ElapsedEventArgs e)
{
try
{
var getDataList = (from x in Funs.DB.Sys_DataExchange where x.IsUpdate == false select x).Take(200).ToList();
if (getDataList.Count() > 0)
{
var getDataList0 = getDataList.Where(x => x.MessageText.Contains("\"Type\":0")).ToList();
var getDataList1 = getDataList.Where(x => x.MessageText.Contains("\"Type\":1")).ToList();
var getDataList2 = getDataList.Where(x => x.MessageText.Contains("\"Type\":2")).ToList();
var getDataList3 = getDataList.Where(x => x.MessageText.Contains("\"Type\":3")).ToList();
var getDataList4 = getDataList.Where(x => x.MessageText.Contains("\"Type\":4")).ToList();
var getDataList5 = getDataList.Where(x => x.MessageText.Contains("\"Type\":5")).ToList();
AddDataItem(getDataList1);
AddDataItem(getDataList0);
AddDataItem(getDataList2);
AddDataItem(getDataList3);
AddDataItem(getDataList4);
AddDataItem(getDataList5);
}
}
catch (Exception ex)
{
StartMonitor();
ErrLogInfo.WriteLog(ex, "博晟数据接口定时器", "RealNameMonitorService.AdUserInProcess");
}
}
#endregion
#region 与博晟培训考试接口数据插入明细方法
/// <summary>
/// 与博晟培训考试接口数据插入明细方法
/// </summary>
/// <param name="getDataExchange"></param>
private static void AddDataItem(List<Model.Sys_DataExchange> getDataExchange)
{
bool isOk = false;
foreach (var item in getDataExchange)
{
JObject obj = JObject.Parse(item.MessageText);
string type = obj["Type"].ToString();
string code = obj["Code"].ToString();
string fromprojectId = obj["DepartId"].ToString();
JArray arr = JArray.Parse(obj["Data"].ToString());
string projectId = string.Empty;
////根据传值项目主键
var getProjectByFromProjectId = Funs.DB.Base_Project.FirstOrDefault(x => x.FromProjectId == fromprojectId);
if (getProjectByFromProjectId != null)
{
projectId = getProjectByFromProjectId.ProjectId;
}
else
{
if (type == "1")
{
projectId = AddProject(arr);
}
}
if (!string.IsNullOrEmpty(projectId))
{
var sysUser = BLL.UserService.GetUserByUserId(BLL.Const.sysglyId);
if (sysUser != null)
{
sysUser.LoginProjectId = projectId;
}
if (type == "0")
{
isOk = AddPerson(projectId, arr, sysUser);
}
else if (type == "1")
{
isOk = AddUnit(projectId, arr, sysUser);
}
else if (type == "2")
{
isOk = AddTrainRecord(projectId, arr, sysUser);
}
else if (type == "3")
{
isOk = AddTrainRecordPerson(projectId, arr, sysUser);
}
else if (type == "4")
{
isOk = AddEduTrain_TrainTest(projectId, arr, sysUser);
}
else if (type == "5")
{
isOk = AddPersonTrainRecord(projectId, arr, sysUser);
}
if (isOk) ///更新数据接收状态
{
item.IsUpdate = true;
Funs.DB.SubmitChanges();
}
}
}
}
#endregion
#region 插入信息-项目信息
/// <summary>
/// 插入信息-项目信息
/// </summary>
/// <param name="projectId"></param>
/// <param name="arr"></param>
public static string AddProject(JArray arr)
{
using (Model.SGGLDB db = new Model.SGGLDB(Funs.ConnString))
{
string projectId = string.Empty;
try
{
foreach (var item in arr)
{
string fromUnitId = item["ID"].ToString();
string departName = item["DepartName"].ToString(); ///单位名称
string departSir = item["DepartSir"].ToString(); ///单位级别 0：非项目部 1：项目部级 2：项目部下级单位
if (!string.IsNullOrEmpty(fromUnitId) && !string.IsNullOrEmpty(departName) && departSir == "1")
{
var getProjectByFromProjectId = db.Base_Project.FirstOrDefault(x => x.FromProjectId == fromUnitId);
if (getProjectByFromProjectId == null)
{
string projectCode = item["ProjectCode"].ToString();
var getProjectByProjectCode = db.Base_Project.FirstOrDefault(x => x.ProjectCode == projectCode);
if (getProjectByProjectCode != null)
{
projectId = getProjectByProjectCode.ProjectId;
getProjectByProjectCode.FromProjectId = fromUnitId;
db.SubmitChanges();
}
}
}
}
}
catch (Exception ex)
{
ErrLogInfo.WriteLog("博晟-项目同步", ex);
}
return projectId;
}
}
#endregion
#region 插入人员信息
/// <summary>
/// 插入人员信息 0
/// </summary>
/// <param name="projectId"></param>
/// <param name="arr"></param>
public static bool AddPerson(string projectId, JArray arr, Model.Sys_User user)
{
using (Model.SGGLDB db = new Model.SGGLDB(Funs.ConnString))
{
bool isOk = true;
try
{
List<Model.Bo_Sheng_Person> insertPersons = new List<Model.Bo_Sheng_Person>();
foreach (var item in arr)
{
string getID = item["ID"].ToString();
var getPerson = db.Bo_Sheng_Person.FirstOrDefault(x => x.ID == getID);
if (!string.IsNullOrEmpty(getID) && getPerson == null)
{
Model.Bo_Sheng_Person newPerson = new Model.Bo_Sheng_Person
{
ID = getID,
ProjectId =projectId,
CreateDate =Funs.GetNewDateTime( item["CreateDate"].ToString()),
CreateUser = item["CreateUser"].ToString(),
OperDate = Funs.GetNewDateTime(item["OperDate"].ToString()),
OperUser = item["OperUser"].ToString(),
DeleteUser = item["DeleteUser"].ToString(),
DeleteDate = Funs.GetNewDateTime(item["DeleteDate"].ToString()),
DeleteTag = item["DeleteTag"].ToString(),
Name = item["Name"].ToString(),
Sex = item["Sex"].ToString(),
BirthDay = Funs.GetNewDateTime(item["BirthDay"].ToString()),
Address = item["Address"].ToString(),
Nation = item["Nation"].ToString(),
IdentifyID = item["IdentifyID"].ToString(),
Kind = item["Kind"].ToString(),
Photo = item["Photo"].ToString(),
Police = item["Police"].ToString(),
ValidPeriodStart = item["ValidPeriodStart"].ToString(),
ValidPeriodEnd = item["ValidPeriodEnd"].ToString(),
Education = item["Education"].ToString(),
Native = item["Native"].ToString(),
Telephone = item["Telephone"].ToString(),
MaritalStatus = item["MaritalStatus"].ToString(),
BloodGroup = item["BloodGroup"].ToString(),
RegisteredType = item["RegisteredType"].ToString(),
Age = Funs.GetNewInt(item["Age"].ToString()),
JobNumber = item["JobNumber"].ToString(),
CardContent = item["CardContent"].ToString(),
ContactTel = item["ContactTel"].ToString(),
SecondContacts = item["SecondContacts"].ToString(),
SecondContactsTel = item["SecondContactsTel"].ToString(),
NewAddress = item["NewAddress"].ToString(),
HealthCondition = item["HealthCondition"].ToString(),
HealthFile = item["HealthFile"].ToString(),
BuildArea = item["BuildArea"].ToString(),
TraPrincipal = item["TraPrincipal"].ToString(),
RegisterDate = Funs.GetNewDateTime(item["RegisterDate"].ToString()),
CategoryType = item["CategoryType"].ToString(),
Station = item["Station"].ToString(),
Category = item["Category"].ToString(),
CategoryLevel = item["CategoryLevel"].ToString(),
EntranceDate = Funs.GetNewDateTime(item["EntranceDate"].ToString()),
IsOut = item["IsOut"].ToString(),
LeaveDate = Funs.GetNewDateTime(item["LeaveDate"].ToString()),
IsBlackList = item["IsBlackList"].ToString(),
AgreementId = item["AgreementId"].ToString(),
HasInsurance = item["HasInsurance"].ToString(),
DeviceNumber = item["DeviceNumber"].ToString(),
IsActive = item["IsActive"].ToString(),
DepartId = item["DepartId"].ToString(),
DepartName = item["DepartName"].ToString(),
OwnerDepartId = item["OwnerDepartId"].ToString(),
UploadTime = Funs.GetNewDateTime(item["UploadTime"].ToString()),
};
insertPersons.Add(newPerson);
}
}
if (insertPersons.Count() > 0)
{
db.Bo_Sheng_Person.InsertAllOnSubmit(insertPersons);
db.SubmitChanges();
}
}
catch (Exception ex)
{
isOk = false;
ErrLogInfo.WriteLog("博晟-人员信息同步", ex);
}
return isOk;
}
}
#endregion
#region 插入信息-单位信息 1
/// <summary>
/// 插入信息-单位信息 1
/// </summary>
/// <param name="projectId"></param>
/// <param name="arr"></param>
public static bool AddUnit(string projectId, JArray arr, Model.Sys_User user)
{
using (Model.SGGLDB db = new Model.SGGLDB(Funs.ConnString))
{
bool isOk = true;
try
{
List<Model.Bo_Sheng_Unit> insertUnits = new List<Model.Bo_Sheng_Unit>();
foreach (var item in arr)
{
string getID = item["ID"].ToString();
var getUnit = db.Bo_Sheng_Unit.FirstOrDefault(x => x.ID == getID);
if (!string.IsNullOrEmpty(getID) && getUnit == null)
{
Model.Bo_Sheng_Unit newUnit = new Model.Bo_Sheng_Unit
{
ID = getID,
ProjectId = projectId,
ParentID = item["ParentID"].ToString(),
DepartCode = item["DepartCode"].ToString(),
ParentCode = item["ParentCode"].ToString(),
DepartName = item["DepartName"].ToString(),
DepartType = item["DepartType"].ToString(),
DepartShortName = item["DepartShortName"].ToString(),
DepartOrder = item["DepartOrder"].ToString(),
State = item["State"].ToString(),
DepartSir = item["DepartSir"].ToString(),
IsEpiboly = item["IsEpiboly"].ToString(),
Phone = item["Phone"].ToString(),
Charge = item["Charge"].ToString(),
Remark = item["Remark"].ToString(),
OwnerDeptID = item["OwnerDeptID"].ToString(),
CreateDate = Funs.GetNewDateTime(item["CreateDate"].ToString()),
CreateUser = item["CreateUser"].ToString(),
OperDate = Funs.GetNewDateTime(item["OperDate"].ToString()),
OperUser = item["OperUser"].ToString(),
};
insertUnits.Add(newUnit);
}
}
if (insertUnits.Count() > 0)
{
db.Bo_Sheng_Unit.InsertAllOnSubmit(insertUnits);
db.SubmitChanges();
}
}
catch (Exception ex)
{
isOk = false;
ErrLogInfo.WriteLog("博晟-单位信息同步", ex);
}
return isOk;
}
}
#endregion
#region 插入培训记录 2
/// <summary>
/// 插入培训记录 2
/// </summary>
/// <param name="projectId"></param>
/// <param name="arr"></param>
public static bool AddTrainRecord(string projectId, JArray arr, Model.Sys_User user)
{
using (Model.SGGLDB db = new Model.SGGLDB(Funs.ConnString))
{
bool isOk = true;
try
{
List<Model.Bo_Sheng_Train> insertTrains = new List<Model.Bo_Sheng_Train>();
foreach (var item in arr)
{
string getID = item["ID"].ToString();
var getTrain = db.Bo_Sheng_Train.FirstOrDefault(x => x.ID == getID);
if (!string.IsNullOrEmpty(getID) && getTrain == null)
{
Model.Bo_Sheng_Train newTrainRecord = new Model.Bo_Sheng_Train
{
ID = getID,
ProjectId =projectId,
DeleteUser = item["DeleteUser"].ToString(),
DeleteDate =Funs.GetNewDateTime( item["DeleteDate"].ToString()),
DeleteTag = item["DeleteTag"].ToString(),
RecordName = item["RecordName"].ToString(),
TrainType = item["TrainType"].ToString(),
PaperMode = item["PaperMode"].ToString(),
TrainMode = item["TrainMode"].ToString(),
TrainPrincipal = item["TrainPrincipal"].ToString(),
TrainStartDate = Funs.GetNewDateTime(item["TrainStartDate"].ToString()),
TrainEndDate = Funs.GetNewDateTime(item["TrainEndDate"].ToString()),
TrainContent = item["TrainContent"].ToString(),
TrainDescript = item["TrainDescript"].ToString(),
TrainPeriod = item["TrainPeriod"].ToString(),
PersonCount = Funs.GetNewInt(item["PersonCount"].ToString()),
PassedCount = Funs.GetNewInt(item["PassedCount"].ToString()),
CoverImg = item["CoverImg"].ToString(),
DemandID = item["DemandID"].ToString(),
CourseCount = Funs.GetNewInt(item["CourseCount"].ToString()),
CourseDuration = item["CourseDuration"].ToString(),
Source = item["Source"].ToString(),
Description = item["Description"].ToString(),
DeviceNo = item["DeviceNo"].ToString(),
OwnerDepartId = item["OwnerDepartId"].ToString(),
UploadTime = Funs.GetNewDateTime(item["UploadTime"].ToString()),
OwnerDeptName = item["OwnerDeptName"].ToString(),
TrainDepart = item["TrainDepart"].ToString(),
CreateDate = Funs.GetNewDateTime(item["CreateDate"].ToString()),
CreateUser = item["CreateUser"].ToString(),
OperDate = Funs.GetNewDateTime(item["OperDate"].ToString()),
OperUser = item["OperUser"].ToString(),
};
insertTrains.Add(newTrainRecord);
}
}
if (insertTrains.Count() > 0)
{
db.Bo_Sheng_Train.InsertAllOnSubmit(insertTrains);
db.SubmitChanges();
}
}
catch (Exception ex)
{
isOk = false;
ErrLogInfo.WriteLog("博晟-培训记录同步", ex);
}
return isOk;
}
}
#endregion
#region 插入培训人员 3
/// <summary>
/// 插入培训人员 3
/// </summary>
/// <param name="projectId"></param>
/// <param name="arr"></param>
public static bool AddTrainRecordPerson(string projectId, JArray arr, Model.Sys_User user)
{
using (Model.SGGLDB db = new Model.SGGLDB(Funs.ConnString))
{
bool isOk = true;
try
{
List<Model.Bo_Sheng_TrainPerson> insertTrainPersons = new List<Model.Bo_Sheng_TrainPerson>();
foreach (var item in arr)
{
string getID = item["ID"].ToString();
var getTrainPerson = db.Bo_Sheng_TrainPerson.FirstOrDefault(x => x.ID == getID);
if (!string.IsNullOrEmpty(getID) && getTrainPerson == null)
{
Model.Bo_Sheng_TrainPerson newPerson = new Model.Bo_Sheng_TrainPerson
{
ID = getID,
ProjectId = projectId,
DeleteUser = item["DeleteUser"].ToString(),
DeleteDate =Funs.GetNewDateTime( item["DeleteDate"].ToString()),
DeleteTag = item["DeleteTag"].ToString(),
EmpName = item["EmpName"].ToString(),
IdentifyId = item["IdentifyId"].ToString(),
Photo = item["Photo"].ToString(),
Station = item["Station"].ToString(),
Category = item["Category"].ToString(),
CategoryName = item["CategoryName"].ToString(),
RecordId = item["RecordId"].ToString(),
SignName = item["SignName"].ToString(),
DepartId = item["DepartId"].ToString(),
DepartName = item["DepartName"].ToString(),
SignInDate = Funs.GetNewDateTime(item["SignInDate"].ToString()),
SignInType = item["SignInType"].ToString(),
TrainPeriod = item["TrainPeriod"].ToString(),
State = item["State"].ToString(),
TotalScore =Funs.GetNewDecimal( item["TotalScore"].ToString()),
PassScore =Funs.GetNewDecimal( item["PassScore"].ToString()),
Score = Funs.GetNewDecimal( item["Score"].ToString()),
IsPass = item["IsPass"].ToString(),
GroupNo = item["GroupNo"].ToString(),
ExamNo = item["ExamNo"].ToString(),
ExamCount = Funs.GetNewInt(item["ExamCount"].ToString()),
DeviceNo = item["DeviceNo"].ToString(),
OwnerDepartId = item["OwnerDepartId"].ToString(),
UploadTime = Funs.GetNewDateTime(item["UploadTime"].ToString()),
Answers = item["Answers"].ToString(),
CreateDate = Funs.GetNewDateTime(item["CreateDate"].ToString()),
CreateUser = item["CreateUser"].ToString(),
OperDate = Funs.GetNewDateTime(item["OperDate"].ToString()),
OperUser = item["OperUser"].ToString(),
};
insertTrainPersons.Add(newPerson);
}
}
if (insertTrainPersons.Count() > 0)
{
db.Bo_Sheng_TrainPerson.InsertAllOnSubmit(insertTrainPersons);
db.SubmitChanges();
}
}
catch (Exception ex)
{
isOk = false;
ErrLogInfo.WriteLog("博晟-培训人员同步", ex);
}
return isOk;
}
}
#endregion
#region 插入试卷 4
/// <summary>
/// 插入试卷 4
/// </summary>
/// <param name="projectId"></param>
/// <param name="arr"></param>
public static bool AddEduTrain_TrainTest(string projectId, JArray arr, Model.Sys_User user)
{
using (Model.SGGLDB db = new Model.SGGLDB(Funs.ConnString))
{
bool isOk = true;
try
{
List<Model.Bo_Sheng_Exam> insertExams = new List<Model.Bo_Sheng_Exam>();
foreach (var item in arr)
{
string getID = item["ID"].ToString();
var getExam = db.Bo_Sheng_Exam.FirstOrDefault(x => x.ID == getID);
if (!string.IsNullOrEmpty(getID) && getExam == null)
{
Model.Bo_Sheng_Exam newTrainTest = new Model.Bo_Sheng_Exam
{
ID = getID,
ProjectId = projectId,
RecordId = item["RecordId"].ToString(),
ExamNo = item["ExamNo"].ToString(),
GroupNo = item["GroupNo"].ToString(),
CourseID = item["CourseID"].ToString(),
COrder =Funs.GetNewInt(item["COrder"].ToString()),
QsnCode = item["QsnCode"].ToString(),
QsnId = item["QsnId"].ToString(),
QsnContent = item["QsnContent"].ToString(),
QsnFileName = item["QsnFileName"].ToString(),
QsnAnswer = item["QsnAnswer"].ToString(),
QsnCategory = item["QsnCategory"].ToString(),
QsnKind = item["QsnKind"].ToString(),
QsnImportant = item["QsnImportant"].ToString(),
Description = item["Description"].ToString(),
Analysis = item["Analysis"].ToString(),
UploadTime = Funs.GetNewDateTime(item["UploadTime"].ToString()),
};
insertExams.Add(newTrainTest);
}
}
if (insertExams.Count() > 0)
{
db.Bo_Sheng_Exam.InsertAllOnSubmit(insertExams);
db.SubmitChanges();
}
}
catch (Exception ex)
{
isOk = false;
ErrLogInfo.WriteLog("博晟-培训试卷同步", ex);
}
return isOk;
}
}
#endregion
#region 插入人员培训记录 5
/// <summary>
/// 插入人员培训记录 5
/// </summary>
/// <param name="projectId"></param>
/// <param name="arr"></param>
public static bool AddPersonTrainRecord(string projectId, JArray arr, Model.Sys_User user)
{
using (Model.SGGLDB db = new Model.SGGLDB(Funs.ConnString))
{
bool isOk = true;
try
{
List<Model.Bo_Sheng_PersonTrainRecord> insertPersonTrainRecords = new List<Model.Bo_Sheng_PersonTrainRecord>();
foreach (var item in arr)
{
string getID = item["ID"].ToString();
var getPersonTrainRecord = db.Bo_Sheng_PersonTrainRecord.FirstOrDefault(x => x.ID == getID);
if (!string.IsNullOrEmpty(getID) && getPersonTrainRecord == null)
{
Model.Bo_Sheng_PersonTrainRecord newRecord = new Model.Bo_Sheng_PersonTrainRecord
{
ID = getID,
ProjectId = projectId,
EmpName = item["EmpName"].ToString(),
IdentifyId = item["IdentifyId"].ToString(),
CategoryName = item["CategoryName"].ToString(),
RecordId = item["RecordId"].ToString(),
DepartId = item["DepartId"].ToString(),
DepartName = item["DepartName"].ToString(),
TrainPeriod = item["TrainPeriod"].ToString(),
TotalScore = Funs.GetNewDecimal(item["TotalScore"].ToString()),
PassScore = Funs.GetNewDecimal(item["PassScore"].ToString()),
Score = Funs.GetNewDecimal(item["Score"].ToString()),
IsPass = item["IsPass"].ToString(),
GroupNo = item["GroupNo"].ToString(),
ExamNo = item["ExamNo"].ToString(),
ExamCount = item["ExamCount"].ToString(),
DeviceNo = item["DeviceNo"].ToString(),
OwnerDepartId = item["OwnerDepartId"].ToString(),
Answers = item["Answers"].ToString(),
RecordName = item["RecordName"].ToString(),
TrainType = item["TrainType"].ToString(),
PaperMode = item["PaperMode"].ToString(),
TrainMode = item["TrainMode"].ToString(),
TrainPrincipal = item["TrainPrincipal"].ToString(),
TrainStartDate = Funs.GetNewDateTime(item["TrainStartDate"].ToString()),
TrainEndDate = Funs.GetNewDateTime(item["TrainEndDate"].ToString()),
TrainContent = item["TrainContent"].ToString(),
TrainDescript = item["TrainDescript"].ToString(),
};
insertPersonTrainRecords.Add(newRecord);
}
}
if (insertPersonTrainRecords.Count() > 0)
{
db.Bo_Sheng_PersonTrainRecord.InsertAllOnSubmit(insertPersonTrainRecords);
db.SubmitChanges();
}
}
catch (Exception ex)
{
isOk = false;
ErrLogInfo.WriteLog("博晟-人员培训记录同步", ex);
}
return isOk;
}
}
#endregion
}
}
SGGL/BLL/BoSheng/BOSHENGService.cs
+500
View File
@@ -0,0 +1,500 @@
using FineUIPro;
using System;
using System.Collections;
using System.Linq;
namespace BLL
{
public static class BOSHENGService
{
public static Model.SGGLDB db = Funs.DB;
#region 获取单位列表
/// <summary>
/// 记录数
/// </summary>
public static int unitcount
{
get;
set;
}
/// <summary>
/// 定义变量
/// </summary>
private static IQueryable<Model.Bo_Sheng_Unit> getUnits = from x in db.Bo_Sheng_Unit select x;
/// <summary>
/// 获取分页列表
/// </summary>
/// <param name="PageIndex">页码</param>
/// <param name="PageSize">每页数量</param>
/// <returns></returns>
public static IEnumerable getUnitListData(string projectId, string departName, string departCode, Grid Grid1)
{
IQueryable<Model.Bo_Sheng_Unit> getDataList = getUnits.Where(x => x.ProjectId == projectId);
if (!string.IsNullOrEmpty(departName))
{
getDataList = getDataList.Where(x => x.DepartName.Contains(departName));
}
if (!string.IsNullOrEmpty(departCode))
{
getDataList = getDataList.Where(x => x.DepartCode.Contains(departCode));
}
unitcount = getDataList.Count();
if (unitcount == 0)
{
return null;
}
getDataList = SortConditionHelper.SortingAndPaging(getDataList, Grid1.SortField, Grid1.SortDirection, Grid1.PageIndex, Grid1.PageSize);
return from x in getDataList
select new
{
x.ID,
x.ProjectId,
x.ParentID,
x.DepartCode,
x.ParentCode,
x.DepartName,
x.DepartType,
x.DepartShortName,
x.DepartOrder,
x.State,
x.DepartSir,
x.IsEpiboly,
x.Phone,
x.Charge,
x.Remark,
x.OwnerDeptID,
x.CreateDate,
x.CreateUser,
x.OperDate,
x.OperUser,
};
}
#endregion
#region 获取人员列表
/// <summary>
/// 记录数
/// </summary>
public static int personcount
{
get;
set;
}
/// <summary>
/// 定义变量
/// </summary>
private static IQueryable<Model.Bo_Sheng_Person> getPersons = from x in db.Bo_Sheng_Person select x;
/// <summary>
/// 获取分页列表
/// </summary>
/// <param name="PageIndex">页码</param>
/// <param name="PageSize">每页数量</param>
/// <returns></returns>
public static IEnumerable getPersonListData(string projectId, string departName, string name, string identifyID, Grid Grid1)
{
IQueryable<Model.Bo_Sheng_Person> getDataList = getPersons.Where(x => x.ProjectId == projectId);
if (!string.IsNullOrEmpty(departName))
{
getDataList = getDataList.Where(x => x.DepartName.Contains(departName));
}
if (!string.IsNullOrEmpty(name))
{
getDataList = getDataList.Where(x => x.Name.Contains(name));
}
if (!string.IsNullOrEmpty(identifyID))
{
getDataList = getDataList.Where(x => x.IdentifyID == identifyID);
}
personcount = getDataList.Count();
if (personcount == 0)
{
return null;
}
getDataList = SortConditionHelper.SortingAndPaging(getDataList.OrderBy(x => x.DepartName), Grid1.SortField, Grid1.SortDirection, Grid1.PageIndex, Grid1.PageSize);
return from x in getDataList
select new
{
x.ID,
x.ProjectId,
x.CreateDate,
x.CreateUser,
x.OperDate,
x.OperUser,
x.DeleteUser,
x.DeleteDate,
x.DeleteTag,
x.Name,
x.Sex,
SexName = x.Sex == "2" ? "女" : "男",
x.BirthDay,
x.Address,
x.Nation,
x.IdentifyID,
x.Kind,
x.Photo,
x.Police,
x.ValidPeriodStart,
x.ValidPeriodEnd,
x.Education,
x.Native,
x.Telephone,
x.MaritalStatus,
x.BloodGroup,
x.RegisteredType,
x.Age,
x.JobNumber,
x.CardContent,
x.ContactTel,
x.SecondContacts,
x.SecondContactsTel,
x.NewAddress,
x.HealthCondition,
x.HealthFile,
x.BuildArea,
x.TraPrincipal,
x.RegisterDate,
x.CategoryType,
x.Station,
x.Category,
x.CategoryLevel,
x.EntranceDate,
x.IsOut,
IsOutName = x.IsOut == "1" ? "是" : "否",
x.LeaveDate,
x.IsBlackList,
IsBlackListName =x.IsBlackList == "1" ? "是" : "否",
x.AgreementId,
x.HasInsurance,
x.DeviceNumber,
x.IsActive,
x.DepartId,
x.DepartName,
x.OwnerDepartId,
x.UploadTime,
};
}
#endregion
#region 获取培训记录列表
/// <summary>
/// 记录数
/// </summary>
public static int traincount
{
get;
set;
}
/// <summary>
/// 定义变量
/// </summary>
private static IQueryable<Model.Bo_Sheng_Train> getTrains = from x in db.Bo_Sheng_Train select x;
/// <summary>
/// 获取分页列表
/// </summary>
/// <param name="PageIndex">页码</param>
/// <param name="PageSize">每页数量</param>
/// <returns></returns>
public static IEnumerable getTrainListData(string projectId, string trainType, string recordName, Grid Grid1)
{
IQueryable<Model.Bo_Sheng_Train> getDataList = getTrains.Where(x => x.ProjectId == projectId);
if (!string.IsNullOrEmpty(trainType))
{
getDataList = getDataList.Where(x => x.TrainType.Contains(trainType));
}
if (!string.IsNullOrEmpty(recordName))
{
getDataList = getDataList.Where(x => x.RecordName.Contains(recordName));
}
traincount = getDataList.Count();
if (traincount == 0)
{
return null;
}
getDataList = SortConditionHelper.SortingAndPaging(getDataList, Grid1.SortField, Grid1.SortDirection, Grid1.PageIndex, Grid1.PageSize);
return from x in getDataList
select new
{
x.ID,
x.ProjectId,
x.DeleteUser,
x.DeleteDate,
x.DeleteTag,
x.RecordName,
x.TrainType,
x.PaperMode,
PaperModeName = x.PaperMode=="0"? "使用原卷" : "重新出卷",
x.TrainMode,
x.TrainPrincipal,
x.TrainStartDate,
x.TrainEndDate,
x.TrainContent,
x.TrainDescript,
x.TrainPeriod,
x.PersonCount,
x.PassedCount,
x.CoverImg,
x.DemandID,
x.CourseCount,
x.CourseDuration,
x.Source,
SourceName = x.Source == "0" ? "项目" : "课程",
x.Description,
x.DeviceNo,
x.OwnerDepartId,
x.UploadTime,
x.OwnerDeptName,
x.TrainDepart,
x.CreateDate,
x.CreateUser,
x.OperDate,
x.OperUser,
};
}
#endregion
#region 获取培训人员列表
/// <summary>
/// 记录数
/// </summary>
public static int trainPersoncount
{
get;
set;
}
/// <summary>
/// 定义变量
/// </summary>
private static IQueryable<Model.Bo_Sheng_TrainPerson> getTrainPersons = from x in db.Bo_Sheng_TrainPerson select x;
/// <summary>
/// 获取分页列表
/// </summary>
/// <param name="PageIndex">页码</param>
/// <param name="PageSize">每页数量</param>
/// <returns></returns>
public static IEnumerable getTrainPersonListData(string projectId,string departName, string name, string identifyID, Grid Grid1)
{
IQueryable<Model.Bo_Sheng_TrainPerson> getDataList = getTrainPersons.Where(x => x.ProjectId == projectId);
if (!string.IsNullOrEmpty(departName))
{
getDataList = getDataList.Where(x => x.DepartName.Contains(departName));
}
if (!string.IsNullOrEmpty(name))
{
getDataList = getDataList.Where(x => x.EmpName.Contains(name));
}
if (!string.IsNullOrEmpty(identifyID))
{
getDataList = getDataList.Where(x => x.IdentifyId.Contains(identifyID));
}
trainPersoncount = getDataList.Count();
if (trainPersoncount == 0)
{
return null;
}
getDataList = SortConditionHelper.SortingAndPaging(getDataList, Grid1.SortField, Grid1.SortDirection, Grid1.PageIndex, Grid1.PageSize);
return from x in getDataList
select new
{
x.ID,
x.ProjectId,
x.DeleteUser,
x.DeleteDate,
x.DeleteTag,
x.EmpName,
x.IdentifyId,
x.Photo,
x.Station,
x.Category,
x.CategoryName,
x.RecordId,
x.SignName,
x.DepartId,
x.DepartName,
x.SignInDate,
x.SignInType,
x.TrainPeriod,
x.State,
StateName= x.State=="0"? "正常" : "补签",
x.TotalScore,
x.PassScore,
x.Score,
x.IsPass,
IsPassName = x.IsPass == "0" ? "否" : "是",
x.GroupNo,
x.ExamNo,
x.ExamCount,
x.DeviceNo,
x.OwnerDepartId,
x.UploadTime,
x.Answers,
x.CreateDate,
x.CreateUser,
x.OperDate,
x.OperUser,
};
}
#endregion
#region 获取试卷列表
/// <summary>
/// 记录数
/// </summary>
public static int examcount
{
get;
set;
}
/// <summary>
/// 定义变量
/// </summary>
private static IQueryable<Model.Bo_Sheng_Exam> getExams = from x in db.Bo_Sheng_Exam select x;
/// <summary>
/// 获取分页列表
/// </summary>
/// <param name="PageIndex">页码</param>
/// <param name="PageSize">每页数量</param>
/// <returns></returns>
public static IEnumerable getExamListData(string projectId, string qsnCode,string qsnContent, Grid Grid1)
{
IQueryable<Model.Bo_Sheng_Exam> getDataList = getExams.Where(x => x.ProjectId == projectId);
if (!string.IsNullOrEmpty(qsnCode))
{
getDataList = getDataList.Where(x => x.QsnCode == qsnCode);
}
if (!string.IsNullOrEmpty(qsnContent))
{
getDataList = getDataList.Where(x => x.QsnContent.Contains(qsnContent));
}
examcount = getDataList.Count();
if (examcount == 0)
{
return null;
}
getDataList = SortConditionHelper.SortingAndPaging(getDataList, Grid1.SortField, Grid1.SortDirection, Grid1.PageIndex, Grid1.PageSize);
return from x in getDataList
select new
{
x.ID,
x.ProjectId,
x.RecordId,
x.ExamNo,
x.GroupNo,
x.CourseID,
x.COrder,
x.QsnCode,
x.QsnId,
x.QsnContent,
x.QsnFileName,
x.QsnAnswer,
x.QsnCategory,
QsnCategoryName= x.QsnCategory=="3"? "图片题" : (x.QsnCategory == "2"? "多媒体题" : "文字题"),
x.QsnKind,
QsnKindName = x.QsnKind == "3" ? "判断" : (x.QsnCategory == "2" ? "多选" : "单选"),
x.QsnImportant,
QsnImportantName = x.QsnImportant == "2" ? "困难" : (x.QsnCategory == "1" ? "一般" : "容易"),
x.Description,
x.Analysis,
x.UploadTime,
};
}
#endregion
#region 获取人员培训记录列表
/// <summary>
/// 记录数
/// </summary>
public static int personTrainRecordcount
{
get;
set;
}
/// <summary>
/// 定义变量
/// </summary>
private static IQueryable<Model.Bo_Sheng_PersonTrainRecord> getPersonTrainRecords = from x in db.Bo_Sheng_PersonTrainRecord select x;
/// <summary>
/// 获取分页列表
/// </summary>
/// <param name="PageIndex">页码</param>
/// <param name="PageSize">每页数量</param>
/// <returns></returns>
public static IEnumerable getPersonTrainRecordListData(string projectId, string departName, string name, string identifyID, Grid Grid1)
{
IQueryable<Model.Bo_Sheng_PersonTrainRecord> getDataList = getPersonTrainRecords.Where(x => x.ProjectId == projectId);
if (!string.IsNullOrEmpty(name))
{
getDataList = getDataList.Where(x => x.EmpName.Contains(name));
}
if (!string.IsNullOrEmpty(departName))
{
getDataList = getDataList.Where(x => x.DepartName.Contains(departName));
}
if (!string.IsNullOrEmpty(identifyID))
{
getDataList = getDataList.Where(x => x.IdentifyId.Contains(identifyID));
}
personTrainRecordcount = getDataList.Count();
if (personTrainRecordcount == 0)
{
return null;
}
getDataList = SortConditionHelper.SortingAndPaging(getDataList, Grid1.SortField, Grid1.SortDirection, Grid1.PageIndex, Grid1.PageSize);
return from x in getDataList
select new
{
x.ID,
x.ProjectId,
x.EmpName,
x.IdentifyId,
x.CategoryName,
x.RecordId,
x.DepartId,
x.DepartName,
x.TrainPeriod,
x.TotalScore,
x.PassScore,
x.Score,
x.IsPass,
IsPassName = x.IsPass == "0" ? "否" : "是",
x.GroupNo,
x.ExamNo,
x.ExamCount,
x.DeviceNo,
x.OwnerDepartId,
x.Answers,
x.RecordName,
x.TrainType,
x.PaperMode,
PaperModeName = x.PaperMode == "0" ? "使用原卷" : "重新出卷",
x.TrainMode,
x.TrainPrincipal,
x.TrainStartDate,
x.TrainEndDate,
x.TrainContent,
x.TrainDescript,
};
}
#endregion
}
}