|
|
|
|
@ -1,4 +1,5 @@ |
|
|
|
|
using DinkToPdf; |
|
|
|
|
using Amazon.Runtime.Internal.Transform; |
|
|
|
|
using DinkToPdf; |
|
|
|
|
using DinkToPdf.Contracts; |
|
|
|
|
using Microsoft.AspNetCore.Hosting; |
|
|
|
|
using Microsoft.AspNetCore.Mvc; |
|
|
|
|
@ -1222,7 +1223,8 @@ END"; |
|
|
|
|
resumeTemplateID = await Db.Ado.GetLongAsync("select top 1 Id from Ghrh_ResumeTemplate where IsEnable=1 and IsPublish=1"); |
|
|
|
|
var sql = @$"DECLARE @ResumeTemplateID BIGINT = {resumeTemplateID}
|
|
|
|
|
|
|
|
|
|
SELECT A.ColumnName, A.ResumeInfoColumnName ColumnNameDesc, D.GroupType, A.MapTableName, A.MapColumnName |
|
|
|
|
SELECT A.ColumnName, A.ResumeInfoColumnName ColumnNameDesc, D.GroupType, A.MapTableName, A.MapColumnName, |
|
|
|
|
A.DataType, A.ColumnType, A.IsRequired, A.DataSourceType, A.DataSource, A.DataSourceID |
|
|
|
|
FROM Ghrh_ResumeInfoColumn A |
|
|
|
|
LEFT JOIN Ghrh_ResumeTemplateInfoGroupColumn B |
|
|
|
|
ON B.ResumeInfoColumnID = A.ID |
|
|
|
|
@ -3681,6 +3683,9 @@ WHERE A.IsEnable = 1 AND C.IsEnable = 1 |
|
|
|
|
|
|
|
|
|
var resume = await base.QuerySingle(x => x.IdCardNo == data.IDCardNo); |
|
|
|
|
|
|
|
|
|
if (resume is null) |
|
|
|
|
continue; |
|
|
|
|
|
|
|
|
|
var deptId = (await Db.Queryable<Ghro_Dept>().Where(x => x.DeptNo == data.DeptNo).FirstAsync())?.DeptID; |
|
|
|
|
var titleId = (await Db.Queryable<Ghra_Title>().Where(x => x.TitleNo == data.TitleNo).FirstAsync())?.TitleID; |
|
|
|
|
var gradeId = (await Db.Queryable<Ghra_Grade>().Where(x => x.GradeNo == data.GradeNo).FirstAsync())?.GradeID; |
|
|
|
|
@ -3870,6 +3875,11 @@ WHERE A.IsEnable = 1 AND C.IsEnable = 1 |
|
|
|
|
#endregion |
|
|
|
|
if (items.Any()) |
|
|
|
|
await Db.Insertable(items).ExecuteCommandAsync(); |
|
|
|
|
|
|
|
|
|
await Db.Updateable<Ghrz_Shihua_OA_Employment>() |
|
|
|
|
.SetColumns(it => new Ghrz_Shihua_OA_Employment() { IsRead = 1 }) |
|
|
|
|
.Where(it => it.EmploymentID == data.EmploymentID) |
|
|
|
|
.ExecuteCommandAsync(); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
catch (Exception E) |
|
|
|
|
@ -3984,6 +3994,221 @@ WHERE A.IsEnable = 1 AND C.IsEnable = 1 |
|
|
|
|
} |
|
|
|
|
#endregion |
|
|
|
|
|
|
|
|
|
#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); |
|
|
|
|
|
|
|
|
|
DataTable dt = new DataTable("TempTable"); |
|
|
|
|
|
|
|
|
|
var formColumns = await QueryResumeFormColumn(); |
|
|
|
|
string fileName = path + SnowFlakeSingle.instance.getID() + ".xlsx"; |
|
|
|
|
|
|
|
|
|
formColumns.Where(x => x.GroupType == "Base") |
|
|
|
|
.ToList() |
|
|
|
|
.ForEach(x => |
|
|
|
|
{ |
|
|
|
|
if (!dt.Columns.Contains(x.ColumnNameDesc)) |
|
|
|
|
dt.Columns.Add(x.ColumnNameDesc, typeof(string)); |
|
|
|
|
}); |
|
|
|
|
|
|
|
|
|
var dr = dt.NewRow(); |
|
|
|
|
dt.Rows.Add(dr); |
|
|
|
|
NPOIHelper.ExportExcel(dt, null, "简历导入模板", physicsPath + fileName); |
|
|
|
|
|
|
|
|
|
var physicsPath1 = physicsPath + 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 formColumns = await QueryResumeFormColumn(); |
|
|
|
|
|
|
|
|
|
formColumns = formColumns.Where(x => x.GroupType == "Base") |
|
|
|
|
.ToList(); |
|
|
|
|
for (int i = 0; i < dt.Rows.Count; i++) |
|
|
|
|
{ |
|
|
|
|
var comments = new List<string>(); |
|
|
|
|
bool isContinue = false; |
|
|
|
|
|
|
|
|
|
var dict = new Dictionary<string, object> |
|
|
|
|
{ |
|
|
|
|
{ "Id", SnowFlakeSingle.Instance.NextId() }, |
|
|
|
|
{ "CreateBy", App.User.ID }, |
|
|
|
|
{ "CreateTime", DateTime.Now }, |
|
|
|
|
{ "UpdateTime", DateTime.Now } |
|
|
|
|
}; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
formColumns.ForEach(x => |
|
|
|
|
{ |
|
|
|
|
if (!dt.Columns.Contains(x.ColumnNameDesc)) |
|
|
|
|
{ |
|
|
|
|
comments.Add("未查询到【" + x.ColumnNameDesc + "】列！"); |
|
|
|
|
data.ErrorCount++; |
|
|
|
|
dt.Rows[i]["Comments"] = string.Join(";", comments.Select(a => a)); |
|
|
|
|
isExistError = true; |
|
|
|
|
isContinue = true; |
|
|
|
|
} |
|
|
|
|
}); |
|
|
|
|
|
|
|
|
|
if (isContinue) |
|
|
|
|
continue; |
|
|
|
|
|
|
|
|
|
for (int j = 0; j < formColumns.Count; j++) |
|
|
|
|
{ |
|
|
|
|
var column = formColumns[j]; |
|
|
|
|
var value = dt.Rows[i][column.ColumnNameDesc].ToString(); |
|
|
|
|
if (column.IsRequired == true && value.IsNullOrEmpty()) |
|
|
|
|
{ |
|
|
|
|
comments.Add(column.ColumnNameDesc + "不能为空！"); |
|
|
|
|
data.ErrorCount++; |
|
|
|
|
dt.Rows[i]["Comments"] = string.Join(";", comments.Select(a => a)); |
|
|
|
|
isExistError = true; |
|
|
|
|
continue; |
|
|
|
|
} |
|
|
|
|
if (column.DataSourceType.IsNullOrEmpty()) |
|
|
|
|
{ |
|
|
|
|
if (column.DataType == "int" || column.DataType == "decimal") |
|
|
|
|
{ |
|
|
|
|
try |
|
|
|
|
{ |
|
|
|
|
Convert.ToInt64(value); |
|
|
|
|
} |
|
|
|
|
catch (Exception) |
|
|
|
|
{ |
|
|
|
|
comments.Add(column.ColumnNameDesc + "无效的数字类型！"); |
|
|
|
|
data.ErrorCount++; |
|
|
|
|
dt.Rows[i]["Comments"] = string.Join(";", comments.Select(a => a)); |
|
|
|
|
isExistError = true; |
|
|
|
|
continue; |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
else if (column.DataType == "date") |
|
|
|
|
{ |
|
|
|
|
try |
|
|
|
|
{ |
|
|
|
|
Convert.ToDateTime(value); |
|
|
|
|
} |
|
|
|
|
catch (Exception) |
|
|
|
|
{ |
|
|
|
|
comments.Add(column.ColumnNameDesc + "无效的日期类型！"); |
|
|
|
|
data.ErrorCount++; |
|
|
|
|
dt.Rows[i]["Comments"] = string.Join(";", comments.Select(a => a)); |
|
|
|
|
isExistError = true; |
|
|
|
|
continue; |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
if (value.IsNotEmptyOrNull()) |
|
|
|
|
{ |
|
|
|
|
if (column.DataSource.IsNotEmptyOrNull() && column.DataSourceType.IsNotEmptyOrNull()) |
|
|
|
|
{ |
|
|
|
|
|
|
|
|
|
if (column.DataSourceType == "CommonList") |
|
|
|
|
{ |
|
|
|
|
var commonSql = await Db.Queryable<Ghrs_ListCommonSql>().Where(x => x.ListCommonSqlId == column.DataSource.ObjToInt()).FirstAsync(); |
|
|
|
|
|
|
|
|
|
if (commonSql != null) |
|
|
|
|
{ |
|
|
|
|
string sql = @$"SELECT [value]
|
|
|
|
|
FROM ({commonSql.SelectSql}) A |
|
|
|
|
WHERE label = '{value}'";
|
|
|
|
|
sql = sql.Replace("{@LangID}", "1"); |
|
|
|
|
var id2 = await Db.Ado.GetLongAsync(sql); |
|
|
|
|
|
|
|
|
|
dict.Add(column.ColumnName, id2); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
else if (column.DataSourceType == "ParaDetailNo") |
|
|
|
|
{ |
|
|
|
|
var sql = @$"SELECT ParaDetailNo
|
|
|
|
|
FROM Ghrs_ParaDetail |
|
|
|
|
WHERE ParaMasterId IN (SELECT ParaMasterId |
|
|
|
|
FROM Ghrs_ParaMaster |
|
|
|
|
WHERE ParaMasterId = {column.DataSource.ObjToInt()}) |
|
|
|
|
AND IsEnable = 1 |
|
|
|
|
AND ParaDetailName = '{value}'";
|
|
|
|
|
var id2 = await Db.Ado.GetStringAsync(sql); |
|
|
|
|
|
|
|
|
|
dict.Add(column.ColumnName, id2); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
else |
|
|
|
|
dict.Add(column.ColumnName, value); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
if (dict.ContainsKey("IdCardNo")) |
|
|
|
|
{ |
|
|
|
|
if (await base.AnyAsync(x => x.IdCardNo == dict["IdCardNo"].ToString())) |
|
|
|
|
{ |
|
|
|
|
comments.Add("证件号码不能重复！"); |
|
|
|
|
data.ErrorCount++; |
|
|
|
|
dt.Rows[i]["Comments"] = string.Join(";", comments.Select(a => a)); |
|
|
|
|
isExistError = true; |
|
|
|
|
continue; |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
if (isExistError) |
|
|
|
|
continue; |
|
|
|
|
try |
|
|
|
|
{ |
|
|
|
|
dict.Add("Status", "WaitRecommended"); |
|
|
|
|
dict.Add("ApplicationStatus", "Submit"); |
|
|
|
|
await Db.Insertable(dict).AS("Ghrh_Resume").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 = "/Advanced" + errorFileName; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
return ServiceResult<ExcelData>.OprateSuccess("导入成功！", data); |
|
|
|
|
} |
|
|
|
|
#endregion |
|
|
|
|
|
|
|
|
|
#region 通用方法 |
|
|
|
|
/// <summary> |
|
|
|
|
/// 记录日志 |
|
|
|
|
|
xiaochanghai
6 months ago