using Aspose.Cells;
using FluentValidation;
using Microsoft.AspNetCore.SignalR;
using NPOI.OpenXmlFormats.Dml.Chart;
using OASystem.API.OAMethodLib;
using OASystem.API.OAMethodLib.Hub.HubClients;
using OASystem.API.OAMethodLib.Hub.Hubs;
using OASystem.API.OAMethodLib.QiYeWeChatAPI;
using OASystem.API.OAMethodLib.QiYeWeChatAPI.AppNotice;
using OASystem.API.OAMethodLib.Quartz.Business;
using OASystem.Domain.Dtos.Groups;
using OASystem.Domain.Dtos.PersonnelModule;
using OASystem.Domain.Entities.Groups;
using OASystem.Domain.Entities.PersonnelModule;
using OASystem.Domain.ViewModels.JuHeExchangeRate;
using OASystem.Domain.ViewModels.PersonnelModule;
using OASystem.Domain.ViewModels.QiYeWeChat;
using OASystem.Infrastructure.Repositories.PersonnelModule;
using System.Collections;
using System.Data;
using System.Diagnostics;
using System.Globalization;
using static OASystem.API.OAMethodLib.JWTHelper;
using static OpenAI.GPT3.ObjectModels.SharedModels.IOpenAiModels;
namespace OASystem.API.Controllers
{
/// <summary>
/// 人事模块
/// </summary>
[Route("api/[controller]/[action]")]
public class PersonnelModuleController : ControllerBase
{
private Result _result;
private readonly IMapper _mapper;
//private readonly decimal _chengDuMinimumWage = 2100.00M;
private readonly IQiYeWeChatApiService _qiYeWeChatApiService;
private readonly WageSheetRepository _wageSheetRep;
private readonly UsersRepository _usersRep;
private readonly TaskAllocationRepository _taskAllocationRep;
private readonly SqlSugarClient _sqlSugar;
private readonly IHubContext<ChatHub, IChatClient> _hubContext;
private readonly GoodsRepository _goodsRep;
private string url;
private string path;
/// <summary>
/// 初始化
/// </summary>
/// <param name="qiYeWeChatApiService"></param>
/// <param name="wageSheetRep"></param>
/// <param name="usersRep"></param>
/// <param name="mapper"></param>
/// <param name="taskAllocationRep"></param>
/// <param name="hubContext"></param>
/// <param name="goodsRep"></param>
/// <param name="sqlSugar"></param>
public PersonnelModuleController(
IHubContext<ChatHub, IChatClient> hubContext,
IMapper mapper,
IQiYeWeChatApiService qiYeWeChatApiService,
WageSheetRepository wageSheetRep,
UsersRepository usersRep,
TaskAllocationRepository taskAllocationRep,
GoodsRepository goodsRep,
SqlSugarClient sqlSugar
)
{
_mapper = mapper;
_usersRep = usersRep;
_qiYeWeChatApiService = qiYeWeChatApiService;
_wageSheetRep = wageSheetRep;
_result = new Result();
_sqlSugar = sqlSugar;
url = AppSettingsHelper.Get("ExcelBaseUrl");
path = AppSettingsHelper.Get("ExcelBasePath");
if (!System.IO.Directory.Exists(path))
{
System.IO.Directory.CreateDirectory(path);//不存在就创建文件夹
}
this._taskAllocationRep = taskAllocationRep;
_hubContext = hubContext;
_goodsRep = goodsRep;
}
#region 工资表单
/// <summary>
/// 工资 月列表
/// </summary>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> GetWageSheetMonth()
{
string sql = string.Format("Select * From Pm_WageIssueWorkingDay Where IsDel = 0 Order By YearMonth Desc");
var data = await _wageSheetRep._sqlSugar.SqlQueryable<WageSheetMonthView>(sql).ToListAsync();
return Ok(JsonView(true, "查询成功!", data));
}
/// <summary>
/// 工资 工作日信息
/// 查询
/// </summary>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> GetWageSheetMonthWorkdays(string startDt, string endDt)
{
//参数处理
var dtFormat = "yyyy-MM-dd";
DateTime startDt1, endDt1;
var startDtIsValid = DateTime.TryParseExact(startDt, dtFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out startDt1);
var endDtIsValid = DateTime.TryParseExact(endDt, dtFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out endDt1);
if (!startDtIsValid) return Ok(JsonView(false, "开始日期格式错误!正确时间格式：yyyy-MM-dd "));
if (!endDtIsValid) return Ok(JsonView(false, "结束格式错误!正确时间格式：yyyy-MM-dd "));
var sql = string.Format(@"Select * From Sys_Calendar
Where Isdel = 0 And Dt between '{0}' And '{1}'", startDt, endDt);
var data = await _wageSheetRep._sqlSugar.SqlQueryable<CalendarInfoView>(sql).ToListAsync();
return Ok(JsonView(true, "查询成功!", data));
}
/// <summary>
/// 工资 工作日信息
/// 编辑
/// </summary>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> GetWageSheetMonthWorkdaysAddOrEdit(WageSheetMonthWorkdaysAddOrEditDto dto)
{
//参数处理
string yearFormat = "yyyy-MM";
string dtFormat = "yyyy-MM-dd";
DateTime yearDt, startDt1, endDt1;
bool yearDtIsValid = DateTime.TryParseExact(dto.YearMonth, yearFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out yearDt);
bool startDtIsValid = DateTime.TryParseExact(dto.StartDate, dtFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out startDt1);
bool endDtIsValid = DateTime.TryParseExact(dto.EndDate, dtFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out endDt1);
if (!yearDtIsValid) return Ok(JsonView(false, "年月日期格式错误!正确时间格式：yyyy-MM "));
if (!startDtIsValid) return Ok(JsonView(false, "开始日期格式错误!正确时间格式：yyyy-MM-dd "));
if (!endDtIsValid) return Ok(JsonView(false, "结束格式错误!正确时间格式：yyyy-MM-dd "));
#region 处理数据
Pm_WageIssueWorkingDay pm_WageIssueWorkingDay1 = new Pm_WageIssueWorkingDay();
pm_WageIssueWorkingDay1 = _mapper.Map<Pm_WageIssueWorkingDay>(dto);
List<Sys_Calendar> sys_Calendars = new List<Sys_Calendar>();
sys_Calendars = _mapper.Map<List<Sys_Calendar>>(dto.CalendarInfos);
if (sys_Calendars.Count > 0)
{
sys_Calendars = sys_Calendars.OrderBy(it => it.Dt).ToList();
}
pm_WageIssueWorkingDay1.Workdays = sys_Calendars.Where(it => it.IsWorkDay == true).ToList().Count;
foreach (var item in sys_Calendars)
{
item.Remark = pm_WageIssueWorkingDay1.Remark;
item.CreateUserId = pm_WageIssueWorkingDay1.CreateUserId;
item.CreateTime = pm_WageIssueWorkingDay1.CreateTime;
}
#endregion
var _sqlSugar = _wageSheetRep._sqlSugar;
_sqlSugar.BeginTran();
try
{
List<Sys_Calendar> sys_Calendars_add = new List<Sys_Calendar>();
List<Sys_Calendar> sys_Calendars_update = new List<Sys_Calendar>();
sys_Calendars_add = sys_Calendars.Where(it => it.Id == 0).OrderBy(it => it.Dt).ToList();
sys_Calendars_update = sys_Calendars.Where(it => it.Id != 0).OrderBy(it => it.Dt).ToList();
//int add1 = 0;
//int upd = 0;
if (sys_Calendars_add.Count > 0)
{
var calendarsAdd = await _sqlSugar.Insertable(sys_Calendars_add).ExecuteReturnIdentityAsync();
if (calendarsAdd < 0)
{
_sqlSugar.RollbackTran();
return Ok(JsonView(false, "工作日/节假日/休息日添加失败!"));
}
}
if (sys_Calendars_update.Count > 0)
{
var calendarsUpdate = await _sqlSugar.Updateable<Sys_Calendar>(sys_Calendars)
.UpdateColumns(it => new { it.Dt, it.IsWorkDay, it.IsHoliDay, it.HoliName })
.WhereColumns(it => it.Id)
.ExecuteCommandAsync();
if (calendarsUpdate < 0)
{
_sqlSugar.RollbackTran();
return Ok(JsonView(false, "工作日/节假日/休息日编辑失败!"));
}
}
var calendarsDatas = await _sqlSugar.Queryable<Sys_Calendar>()
.Where(it => Convert.ToDateTime(it.Dt) >= Convert.ToDateTime(dto.StartDate) && Convert.ToDateTime(it.Dt) <= Convert.ToDateTime(dto.EndDate)).ToListAsync();
if (calendarsDatas.Count < 0)
{
_sqlSugar.RollbackTran();
return Ok(JsonView(false, "日期包暂无工作日/节假日/休息日的信息!"));
}
//月份表是否存在
Pm_WageIssueWorkingDay pm_WageIssueWorkingDay = new Pm_WageIssueWorkingDay()
{
YearMonth = dto.YearMonth,
StartDate = dto.StartDate,
EndDate = dto.EndDate,
Workdays = calendarsDatas.Where(it => it.IsWorkDay == true).ToList().Count
};
string sql = string.Format("Select * From Pm_WageIssueWorkingDay Where Isdel = 0 And YearMonth='{0}'", dto.YearMonth);
var workdsys = await _sqlSugar.SqlQueryable<Pm_WageIssueWorkingDay>(sql).FirstAsync();
pm_WageIssueWorkingDay.CreateUserId = dto.UserId;
pm_WageIssueWorkingDay.IsDel = 0;
if (workdsys == null) //添加
{
int addId = await _sqlSugar.Insertable(pm_WageIssueWorkingDay).ExecuteReturnIdentityAsync();
if (addId < 0)
{
_sqlSugar.RollbackTran();
return Ok(JsonView(false, "工作日设置添加失败!"));
}
}
else //更新
{
int updCount = await _sqlSugar.Updateable(pm_WageIssueWorkingDay)
.IgnoreColumns(z => new { z.CreateUserId, z.CreateTime, z.DeleteUserId, z.DeleteTime, z.IsDel })
.WhereColumns(it => it.YearMonth)
.ExecuteCommandAsync();
if (updCount < 0)
{
_sqlSugar.RollbackTran();
return Ok(JsonView(false, "工作日设置编辑失败!"));
}
}
_sqlSugar.CommitTran();
return Ok(JsonView(true, "操作成功!"));
}
catch (Exception ex)
{
_sqlSugar.RollbackTran();
return Ok(JsonView(false, ex.Message));
}
}
/// <summary>
/// 工资表单 基础数据源
/// </summary>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> GetWageSheetBasicsDataSource()
{
string companySql = string.Format("Select * From Sys_Company Where IsDel = 0");
var compnayData = await _wageSheetRep._sqlSugar.SqlQueryable<CompanyNameView>(companySql).ToListAsync();
string depSql = string.Format("Select * From Sys_Department Where IsDel = 0");
var depData = await _wageSheetRep._sqlSugar.SqlQueryable<Domain.ViewModels.System.DepartmentView>(depSql).ToListAsync();
//获取OA系统内所有用户
var nameData = await _usersRep.GetUserNameList(1);
if (nameData.Code != 0)
{
return Ok(JsonView(false, nameData.Msg));
}
var data = new
{
compnayData = compnayData,
depData = depData,
userNames = nameData.Data
};
return Ok(JsonView(true, "查询成功!", data));
}
/// <summary>
/// 获取工资发放月份
/// </summary>
/// <param name="dto"></param>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> GetWageYaerMonths(WageYearDto dto)
{
string sql = string.Format(@"Select * From Pm_WageIssueWorkingDay
Where Isdel = 0 And YearMonth Like '%{0}%'
Order By YearMonth Asc", dto.Year);
var data = await _wageSheetRep._sqlSugar.SqlQueryable<WageYearMonthView>(sql).ToListAsync();
return Ok(JsonView(true, "操作成功!", data));
}
/// <summary>
/// 获取工资表单
/// </summary>
/// <param name="dto"></param>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> GetWageSheetList(WageSheetListDto dto)
{
//参数处理
string ymFormat = "yyyy-MM";
DateTime yearMonthDt;
bool yearMonthDttIsValid = DateTime.TryParseExact(dto.YearMonth, ymFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out yearMonthDt);
if (!yearMonthDttIsValid)
{
_result.Msg = "年月格式错误!正确时间格式：yyyy-MM ";
return Ok(JsonView(false, _result.Msg));
}
//获取月工资数据
string yearMonth = yearMonthDt.ToString("yyyy-MM");
if (dto.PortType == 1)
{
_result = await _wageSheetRep.Get_WageSheet_ListByYearMonthAsync(yearMonth);
if (_result.Code != 0)
{
return Ok(JsonView(false, _result.Msg));
}
}
else if (dto.PortType == 2)
{ }
else if (dto.PortType == 3)
{ }
else
{
return Ok(JsonView(false, "请选择正确的端口参数"));
}
return Ok(JsonView(true, _result.Msg, _result.Data));
}
/// <summary>
/// 获取工资 详情
/// </summary>
/// <param name="dto"></param>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> GetWageSheetById(WageSheetInfoDto dto)
{
if (dto.PortType == 1)
{
_result = await _wageSheetRep.Get_WageSheet_InfoByIdAsync(dto.Id);
if (_result.Code != 0)
{
return Ok(JsonView(false, _result.Msg));
}
}
else if (dto.PortType == 2)
{ }
else if (dto.PortType == 3)
{ }
else
{
return Ok(JsonView(false, "请选择正确的端口参数"));
}
return Ok(JsonView(true, _result.Msg, _result.Data));
}
/// <summary>
/// 人事模块 工资表单 删除
/// </summary>
/// <param name="dto"></param>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> PostWageSheetDel(WageDelDto dto)
{
try
{
_result = await _wageSheetRep.Post_WageSheet_DelAsync(dto);
if (_result.Code != 0)
{
return Ok(JsonView(false, _result.Msg));
}
}
catch (Exception ex)
{
return Ok(JsonView(false, ex.Message));
}
return Ok(JsonView(true, _result.Msg, _result.Data));
}
/// <summary>
/// 人事模块 工资表单 添加 Or 修改
/// </summary>
/// <param name="dto"></param>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> PostWageSheetAddOrEdit(WageAddOrEditDto dto)
{
try
{
Pm_WageSheet pm_WageSheet = new Pm_WageSheet();
pm_WageSheet = _mapper.Map<Pm_WageSheet>(dto);
pm_WageSheet.LastUpdateUserId = dto.CreateUserId;
#region 计算工资
//月工资
decimal salary = pm_WageSheet.Basic + pm_WageSheet.Floats + pm_WageSheet.PostAllowance + pm_WageSheet.InformationSecurityFee + pm_WageSheet.OtherSubsidies;
//扣款合计
decimal totalDeduction = pm_WageSheet.SickLeave + pm_WageSheet.SomethingFalse + pm_WageSheet.LateTo + pm_WageSheet.LeaveEarly + pm_WageSheet.Absenteeism + pm_WageSheet.NotPunch +
pm_WageSheet.ReservedFunds + pm_WageSheet.WithholdingInsurance + pm_WageSheet.OtherDeductions + pm_WageSheet.OtherDeductions;
//实发合计 不含个税
if (pm_WageSheet.RegularDays >= pm_WageSheet.WorkDays)
{
pm_WageSheet.RegularDays = pm_WageSheet.WorkDays;
salary = salary + pm_WageSheet.Mealsupplement + pm_WageSheet.OtherHandle;
}
else
{
if (dto.UserId == 21) //21==张海麟
{
salary = salary + pm_WageSheet.Mealsupplement + pm_WageSheet.OtherHandle;
}
else
{
salary = PayrollComputation.ConvertToDecimal(salary / pm_WageSheet.WorkDays * pm_WageSheet.RegularDays + pm_WageSheet.Mealsupplement + pm_WageSheet.OtherHandle);
}
}
decimal actualTotal = salary - totalDeduction;
pm_WageSheet.Should = salary;
pm_WageSheet.TotalDeductions = totalDeduction;
pm_WageSheet.TotalRealHair = actualTotal - pm_WageSheet.WithholdingTax;
pm_WageSheet.AfterTax = actualTotal - pm_WageSheet.WithholdingTax;
#endregion
_result = await _wageSheetRep.Post_WageSheet_AddOrEditAsync(dto, pm_WageSheet);
if (_result.Code != 0)
{
return Ok(JsonView(false, _result.Msg));
}
}
catch (Exception ex)
{
return Ok(JsonView(false, ex.Message));
}
return Ok(JsonView(true, _result.Msg, _result.Data));
}
/// <summary>
/// 计算工资
/// </summary>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> SalaryCalculatorAsync(SalaryCalculatorDto dto)
{
Result result = new Result();
Stopwatch sw = new Stopwatch();
sw.Start();
//参数处理
string ymFormat = "yyyy-MM";
string dtFormat = "yyyy-MM-dd";
DateTime yearMonthDt, startDt, endDt;
bool yearMonthDtIsValid = DateTime.TryParseExact(dto.yearMonth, ymFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out yearMonthDt);
bool startDtIsValid = DateTime.TryParseExact(dto.startDt, dtFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out startDt);
bool endDtIsValid = DateTime.TryParseExact(dto.endDt, dtFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out endDt);
if (!yearMonthDtIsValid) return Ok(JsonView(false, "年月格式错误!正确时间格式：yyyy-MM "));
if (!startDtIsValid) return Ok(JsonView(false, "开始日期格式错误!正确时间格式：yyyy-MM-dd "));
if (!endDtIsValid) return Ok(JsonView(false, "结束格式错误!正确时间格式：yyyy-MM-dd "));
string thisYearMonth = dto.yearMonth;
string preYearMonth = yearMonthDt.AddMonths(-1).ToString("yyyy-MM");
//计算本月工资起止时间 比如是2月的1号-28号，那就是2月1号的零点到3月1号的零点
DateTime thisStartDt = startDt;
DateTime thisEndDt = endDt; //
//本月工资是否有数据 有数据则不计算
result = await _wageSheetRep.Get_WageSheet_ListByYearMonthAsync(thisYearMonth);
if (result.Code == 0)
{
return Ok(JsonView(false, thisYearMonth + " 工资数据已存在,若无人员工资请手动添加!"));
}
//获取上个月工资信息
List<Pm_WageSheet> preWageSheetItems = await _wageSheetRep._sqlSugar.Queryable<Pm_WageSheet>().Where(it => it.IsDel == 0 && it.YearMonth == preYearMonth).ToListAsync();
preWageSheetItems = preWageSheetItems.OrderBy(it => it.UserId).ToList();
if (preWageSheetItems.Count <= 0)
{
return Ok(JsonView(false, thisYearMonth + " 上月工资数据不存在,请手动添加!"));
}
//处理上个月同月同人 多条数据
List<Pm_WageSheet> preWageSheetItems1 = new List<Pm_WageSheet>();
//preWageSheetItems1 = preWageSheetItems.GroupBy(it => new { it.YearMonth, it.UserId })
// .Select(it => it.FirstOrDefault(item => item.Basic != 0))
// .ToList();
preWageSheetItems1 = preWageSheetItems
.GroupBy(it => new { it.YearMonth, it.UserId })
.Select(it => it.FirstOrDefault(item => item.Basic != 0))
.Where(it => it != null)
.ToList()!;
//获取OA系统内所有用户
List<UserNameView> userNames = _usersRep._sqlSugar.SqlQueryable<UserNameView>("Select Id,CnName From Sys_Users").ToList();
List<Pm_WageSheet> wageSheets = new List<Pm_WageSheet>();
_result = await PayrollComputation.SalaryCalculatorAsync(preWageSheetItems1, userNames, dto.UserId, thisYearMonth, thisStartDt, thisEndDt);
#region 批量添加
if (_result.Code != 0)
{
return Ok(JsonView(false, _result.Msg));
}
wageSheets = _result.Data;
var add = await _wageSheetRep._sqlSugar.Insertable(wageSheets).ExecuteCommandAsync();
if (add <= 0)
{
return Ok(JsonView(false, "操作失败!"));
}
#endregion
#region 处理返回数据
//List <WageSheetItemInfoView> wageSheetItems = new List<WageSheetItemInfoView>();
//wageSheetItems = _mapper.Map<List<WageSheetItemInfoView>>(wageSheets);
//wageSheetItems = wageSheetItems.Select(it =>
// {
// UserNameView? uName1 = new UserNameView();
// UserNameView? uName2 = new UserNameView();
// uName1 = userNames.Where(it1 => it.UserId == it1.Id).FirstOrDefault();
// if (uName1 != null) it.Name = uName1.CnName;
// uName2 = userNames.Where(it1 => it.LastUpdateUserId == it1.Id).FirstOrDefault();
// if (uName2 != null) it.LastUpdateUserName = uName2.CnName;
// return it; }
// ).ToList();
#endregion
sw.Stop();
return Ok(JsonView(true, "操作成功! 耗时：" + (sw.ElapsedMilliseconds / 1000) + "s"));
}
/// <summary>
/// 计算工资 By YearMonth And UserId
/// </summary>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> SalaryCalculatorSingleAsync(SalaryCalculatorSingleDto dto)
{
Result result = new Result();
Stopwatch sw = new Stopwatch();
sw.Start();
//参数处理
string ymFormat = "yyyy-MM";
string ymdFormat = "yyyy-MM-dd";
DateTime yearMonthDt, startDt, endDt;
bool yearMonthDtIsValid = DateTime.TryParseExact(dto.YearMonth, ymFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out yearMonthDt);
bool startDtIsValid = DateTime.TryParseExact(dto.StartDate, ymdFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out startDt);
bool endDtIsValid = DateTime.TryParseExact(dto.EndDate, ymdFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out endDt);
if (!yearMonthDtIsValid) return Ok(JsonView(false, "年月格式错误!正确时间格式：yyyy-MM "));
if (!startDtIsValid) return Ok(JsonView(false, "开始时间格式错误!正确时间格式：yyyy-MM-dd "));
if (!yearMonthDtIsValid) return Ok(JsonView(false, "结束时间格式错误!正确时间格式：yyyy-MM-dd "));
List<Pm_WageSheet> wageSheets = new List<Pm_WageSheet>();
Pm_WageSheet wageSheet = _mapper.Map<Pm_WageSheet>(dto);
Pm_WageSheet wageSheet1 = await _wageSheetRep._sqlSugar.Queryable<Pm_WageSheet>().Where(it => it.UserId == dto.UserId && it.YearMonth == dto.YearMonth && it.StartDate == dto.StartDate && it.EndDate == dto.EndDate).FirstAsync();
if (wageSheet1 != null)
{
wageSheet.Id = wageSheet1.Id;
}
wageSheets.Add(wageSheet);
//获取OA系统内所有用户
List<UserNameView> userNames = _usersRep._sqlSugar.SqlQueryable<UserNameView>("Select Id,CnName From Sys_Users").ToList();
_result = await PayrollComputation.SalaryCalculatorAsync(wageSheets, userNames, dto.UserId, dto.YearMonth, startDt, endDt);
if (_result.Code != 0)
{
return Ok(JsonView(false, _result.Msg));
}
List<Pm_WageSheet> wageSheets1 = new List<Pm_WageSheet>();
wageSheets1 = _result.Data;
#region 处理返回数据
List<WageSheetInfoView> wageSheetItems = new List<WageSheetInfoView>();
wageSheetItems = _mapper.Map<List<WageSheetInfoView>>(wageSheets1);
wageSheetItems = wageSheetItems.Select(it =>
{
UserNameView? uName1 = new UserNameView();
UserNameView? uName2 = new UserNameView();
uName1 = userNames.Where(it1 => it.UserId == it1.Id).FirstOrDefault();
if (uName1 != null) it.Name = uName1.CnName;
uName2 = userNames.Where(it1 => it.LastUpdateUserId == it1.Id).FirstOrDefault();
if (uName2 != null) it.LastUpdateUserName = uName2.CnName;
return it;
}
).ToList();
#endregion
sw.Stop();
return Ok(JsonView(true, "操作成功!耗时：" + (sw.ElapsedMilliseconds / 1000) + "s", wageSheetItems[0]));
}
/// <summary>
/// 导出工资单
/// </summary>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> ExportWageCard(string yearMonth)
{
Result result = new Result();
Stopwatch sw = new Stopwatch();
sw.Start();
//参数处理
string ymFormat = "yyyy-MM";
DateTime yearMonthDt;
bool yearMonthDtIsValid = DateTime.TryParseExact(yearMonth, ymFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out yearMonthDt);
if (!yearMonthDtIsValid) return Ok(JsonView(false, "年月格式错误!正确时间格式：yyyy-MM "));
//公司部门
string sql = string.Format(@"Select row_number() over(order by pm_ws.Id) as Row_Number,
sc.Id as CompanyId,sc.CompanyName,sd.Id as DepId,sd.DepName,
sys_u1.CnName Name,sys_u2.CnName LastUpdateUserName,pm_ws.*
From Pm_WageSheet pm_ws
Left Join Sys_Users sys_u1 On pm_ws.UserId = sys_u1.Id
Left Join Sys_Users sys_u2 On pm_ws.LastUpdateUserId = sys_u2.Id
Left Join Sys_Company sc On sys_u1.companyId = sc.Id
Left Join Sys_Department sd On sys_u1.DepId = sd.Id
Where pm_ws.IsDel = 0 And pm_ws.YearMonth = '{0}'", yearMonth);
var wageSheetList = await _wageSheetRep._sqlSugar.SqlQueryable<ExportWageSheetItemView>(sql).ToListAsync();
if (wageSheetList.Count <= 0)
{
return Ok(JsonView(false, yearMonth + "暂无工资数据!"));
}
decimal SumPrice = 0.00M;
foreach (var item in wageSheetList)
{
SumPrice += item.AfterTax;
}
WorkbookDesigner designer = new WorkbookDesigner();
designer.Workbook = new Workbook(AppSettingsHelper.Get("ExcelBasePath") + "Template/工资详细清单.xlsx");
designer.Workbook.Worksheets[0].Name = yearMonth + " 工资单";
designer.SetDataSource("WageSheet", wageSheetList);
designer.SetDataSource("YearMonth", yearMonth);
designer.SetDataSource("StartEndDt", wageSheetList[0].StartDate + " - " + wageSheetList[0].EndDate);
designer.SetDataSource("WorkDays", wageSheetList[0].WorkDays);
designer.SetDataSource("SumPrice", SumPrice);
designer.SetDataSource("WageSheetTitle", "工资单");//
designer.Process();
string fileName = "WageCard/" + yearMonth + "_工资单_" + DateTime.Now.ToString("yyyyMMddHHmmss") + ".xlsx";
string path = AppSettingsHelper.Get("ExcelBasePath");
designer.Workbook.Save(path + fileName);
designer = null;
string excelPath = AppSettingsHelper.Get("ExcelFtpPath") + fileName;
string url = AppSettingsHelper.Get("ExcelBaseUrl");
string fileUrl = url + excelPath;
sw.Stop();
return Ok(JsonView(true, "操作成功!耗时：" + (sw.ElapsedMilliseconds / 1000) + "s", new { FileUrl = fileUrl }));
}
/// <summary>
/// 下载个税模板
/// </summary>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> WageSheetTaxTemplate()
{
string serverUrl = AppSettingsHelper.Get("WageSheetExcelBaseUrl");
var userData = await _usersRep.GetUserNameList(1);
if (userData.Code == 0)
{
var userNames = userData.Data;
List<string> names = new List<string>();
List<UserNameView> users = new List<UserNameView>();
names.Add("管理员");
names.Add("国交共享号");
names.Add("人事审核号");
names.Add("国交主管号");
List<TaxTemlateViuw> taxs = new List<TaxTemlateViuw>();
users = JsonConvert.DeserializeObject<List<UserNameView>>(JsonConvert.SerializeObject(userNames));
foreach (UserNameView item in users)
{
string uName = item.CnName;
if (!names.Contains(uName))
{
taxs.Add(new TaxTemlateViuw { UserName = item.CnName });
}
}
if (taxs.Count > 0)
{
WorkbookDesigner designer = new WorkbookDesigner();
designer.Workbook = new Workbook(AppSettingsHelper.Get("ExcelBasePath") + "Template/个税导入模板.xlsx");
designer.Workbook.Worksheets[0].Name = "个税模板";
designer.SetDataSource("TaxTemp", taxs);
designer.Process();
string fileName = "WageSheetTaxFile/个税模板" + DateTime.Now.ToString("yyyyMMddHHmmss") + ".xlsx";
string path = AppSettingsHelper.Get("ExcelBasePath");
designer.Workbook.Save(path + fileName);
designer = null;
string excelPath = AppSettingsHelper.Get("ExcelFtpPath") + fileName;
string url = AppSettingsHelper.Get("ExcelBaseUrl");
string fileUrl = url + excelPath;
return Ok(JsonView(true, "操作成功!", new { FileUrl = fileUrl }));
}
}
return Ok(JsonView(false, "操作失败!"));
}
/// <summary>
/// 上传个税
/// </summary>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> UploadTax(IFormFile file)
{
try
{
var yearMonth = Request.Headers["YearMonth"].ToString();
//string yearMonth = "2023-10";
string ymFormat = "yyyy-MM";
DateTime yearMonthDt;
bool yearMonthDtIsValid = DateTime.TryParseExact(yearMonth, ymFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out yearMonthDt);
if (!yearMonthDtIsValid) return Ok(JsonView(false, "年月格式错误!正确时间格式：yyyy-MM "));
if (file != null)
{
var fileDir = AppSettingsHelper.Get("WageSheetExcelFptPath");
//文件名称
string projectFileName = file.FileName;
//上传的文件的路径
string filePath = "";
if (!Directory.Exists(fileDir))
{
Directory.CreateDirectory(fileDir);
}
//上传的文件的路径
filePath = fileDir + $@"\{projectFileName}";
if (System.IO.File.Exists(filePath))
{
//删除文件
System.IO.File.Delete(filePath);
}
using (FileStream fs = System.IO.File.Create(filePath))
{
file.CopyTo(fs);
fs.Flush();
}
if (System.IO.File.Exists(filePath))
{
Workbook book = new Workbook(filePath);
DataSet dataSet = new DataSet();
if (book.Worksheets.Count > 0)
{
var sheet = book.Worksheets[0];
if (sheet != null)
{
// sheets 中的数据必须存在
if (sheet.Cells.MaxDataRow != -1 && sheet.Cells.MaxDataColumn != -1)
{
// 方法 ExportDataTable 的参数说明
// 要导出的第一个单元格的行号。
// 要导出的第一个单元格的列号。
// 要导入的行数。
// 要导入的列数。
// 指示第一行的数据是否导出到DataTable的列名。
DataTable dataTable = sheet.Cells.ExportDataTable(0, 0, sheet.Cells.MaxDataRow + 1, sheet.Cells.MaxDataColumn + 1, true);
dataSet.Tables.Add(dataTable);
DataTable taxData = dataSet.Tables[0];
//公司部门
string sql = string.Format(@"Select row_number() over(order by pm_ws.Id) as Row_Number,
sc.Id as CompanyId,sc.CompanyName,sd.Id as DepId,sd.DepName,
sys_u1.CnName Name,sys_u2.CnName LastUpdateUserName,pm_ws.*
From Pm_WageSheet pm_ws
Left Join Sys_Users sys_u1 On pm_ws.UserId = sys_u1.Id
Left Join Sys_Users sys_u2 On pm_ws.LastUpdateUserId = sys_u2.Id
Left Join Sys_Company sc On sys_u1.companyId = sc.Id
Left Join Sys_Department sd On sys_u1.DepId = sd.Id
Where pm_ws.IsDel = 0 And pm_ws.YearMonth = '{0}'
Order By UserId Asc ", yearMonth);
var wageSheetList = await _wageSheetRep._sqlSugar.SqlQueryable<WageSheetInfoView>(sql).ToListAsync();
if (wageSheetList.Count <= 0)
{
return Ok(JsonView(false, yearMonth + "工资数据不存在,请先添加工资数据!"));
}
for (int i = 0; i < taxData.Rows.Count; i++)
{
string name = taxData.Rows[i][0].ToString().Trim();
List<WageSheetInfoView> wageSheets = new List<WageSheetInfoView>();
wageSheets = wageSheetList.Where(it => it.Name.Equals(name)).ToList();
if (wageSheets.Count > 0)
{
wageSheetList.Where(it => it.Name.Equals(name))
.Select(it =>
{
//修改 绩效不等于0.00M的数据
//decimal oldTax = it.WithholdingTax;
var newTax = Convert.ToDecimal(taxData.Rows[i][1].ToString());
it.WithholdingTax = newTax;
it.TotalRealHair = it.Should - it.TotalDeductions - newTax;
return it;
})
.ToList();
}
}
List<Pm_WageSheet> wageSheets1 = new List<Pm_WageSheet>();
wageSheets1 = _mapper.Map<List<Pm_WageSheet>>(wageSheetList);
var updateStatus = _wageSheetRep._sqlSugar
.Updateable(wageSheets1)
.UpdateColumns(it => new { it.WithholdingTax, it.TotalRealHair })
.ExecuteCommand();
if (updateStatus < 0)
{
return Ok(JsonView(false, "操作失败！"));
}
if (System.IO.File.Exists(filePath))
{
//删除文件
System.IO.File.Delete(filePath);
}
return Ok(JsonView(true, "操作成功!"));
}
}
else
{
return Ok(JsonView(false, "工作薄没有数据！"));
}
}
}
return Ok(JsonView(true, "上传成功！", projectFileName));
}
else
{
return Ok(JsonView(false, "上传失败！"));
}
}
catch (Exception ex)
{
return Ok(JsonView(false, "程序错误！"));
throw;
}
//return Ok(JsonView(true, "操作成功!"));
}
/// <summary>
/// 打卡记录测试
/// </summary>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> Test(string startDt, string endDt, int code)
{
UserIdListView userIdListView = await _qiYeWeChatApiService.GetUserIdListAsync();
if (userIdListView.errcode != 0)
{
_result.Msg = "【企业微信】【打卡】【获取员工ID】【Msg】" + userIdListView.errmsg;
return Ok(JsonView(false, _result.Msg));
}
List<string> qyWhchatIdList = new List<string>();
//qyWhchatIdList = userIdListView.dept_user.Select(it => it.userid).ToList();
qyWhchatIdList = userIdListView.dept_user.Select(it => it.userid!).ToList();
var data = await _qiYeWeChatApiService.GetCheckinDataAsync(qyWhchatIdList, code, Convert.ToDateTime(startDt), Convert.ToDateTime(endDt));
return Ok(JsonView(true, "操作成功!", data.checkindata));
}
/// <summary>
/// 审批详情
/// </summary>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> PostApprovalDetailAsync(string spNo)
{
if (string.IsNullOrEmpty(spNo))
{
return Ok(JsonView(false, "审批单号不能为空!!"));
}
var data = await _qiYeWeChatApiService.GetApprovalDetailAsync(spNo);
return Ok(JsonView(true, "操作成功!", data));
}
#endregion
#region 任务单
/// <summary>
/// 任务分配
/// 基础数据源
/// </summary>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> PostTaskAllocationInit(TaskAllocationInitDto dto)
{
#region 参数验证
if (dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
if (dto.PageId < 1) dto.PageId = 172; //任务指派Id
PageFunAuthViewBase pageFunAuthView = new PageFunAuthViewBase();
#region 页面操作权限验证
pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(dto.UserId, dto.PageId);
if (pageFunAuthView.CheckAuth == 0) return Ok(JsonView(false, "您没有查看权限!"));
#endregion
#endregion
var _view = await _taskAllocationRep._Init(dto.PortType, dto.UserId);
if (_view.Code == 0)
{
return Ok(JsonView(true, "查询成功!", _view.Data));
}
return Ok(JsonView(false, _view.Msg));
}
/// <summary>
/// 任务分配
/// page
/// </summary>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> PostTaskAllocationPage(TaskAllocationPageDto dto)
{
#region 参数验证
if (dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
if (dto.PageId < 1) dto.PageId = 172; //任务指派Id
PageFunAuthViewBase pageFunAuthView = new PageFunAuthViewBase();
#region 页面操作权限验证
pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(dto.UserId, dto.PageId);
if (pageFunAuthView.CheckAuth == 0) return Ok(JsonView(false, "您没有查看权限!"));
#endregion
#endregion
var groupNames = dto.GroupNames;
var groupArr = Array.Empty<string>();
if (!string.IsNullOrEmpty(groupNames))
{
groupArr = groupNames.Split(',').Select(part => part.Trim()).ToArray();
}
string whereSql = "" ,currUserName = "";
#region 分页参数处理
//类型处理
if (dto.Type == 0) whereSql = "";
else if (dto.Type == 1) //1 由我指派
{
//whereSql = string.Format(@" And ta.CreateUserId = {0} Or (Select COUNT(1) As PeopleNumber From Pm_TaskRelevanceUser Where IsDel = 0 And ta.Id = TAId And UserId = {0}) > 0", dto.UserId);
}
else if (dto.Type == 2)// 2 指派给我
{
//whereSql = string.Format(@" And (Select COUNT(1) As PeopleNumber From Pm_TaskRelevanceUser Where IsDel = 0 And ta.Id = TAId And UserId = {0}) > 0", dto.UserId);
}
//状态 -1 全部 0 未开始 1 进行中 2 待审核 3 未完成 4 已完成
if (dto.Status == -1) //全部
{
whereSql += "";
}
else
{
whereSql += string.Format(@" And ta.Status = {0} ", dto.Status);
}
//任务名称
if (!string.IsNullOrEmpty(dto.TaskName))
{
whereSql += string.Format(@" And ta.TaskName Like '%{0}%' ", dto.TaskName);
}
#endregion
var currUserInfo = await _sqlSugar.Queryable<Sys_Users>().FirstAsync(x => x.Id == dto.UserId);
if (currUserInfo != null) currUserName = currUserInfo.CnName;
string pageSql = string.Format(@"Select
ROW_NUMBER() OVER(
ORDER BY
CreateTime Desc
) AS RowNumber,
*
From
(
Select
ta.Id,
ta.TaskName,
ta.TaskContent,
ta.TaskPriority,
d.DepName,
di.TeamName,
ta.Status,
ta.PredictBeginTime,
ta.PredictEndTime,
u.CnName As CreateUserName,
ta.CreateTime,
(
SELECT
STUFF(
(
Select
',' + u.CnName
From
Pm_TaskRelevanceUser tra
Left Join Sys_Users u On tra.UserId = u.Id
Where
tra.Isdel = 0
And tra.TAId = ta.Id FOR XML PATH('')
),
1,
1,
''
)
) As Participant,
(
SELECT
STUFF(
(
Select
',' + u.CnName
From
Pm_TaskRelevanceUser tra
Left Join Sys_Users u On tra.UserId = u.Id
Where
tra.Isdel = 0
And tra.TAId = ta.Id
And tra.TaskStatus = 4 FOR XML PATH('')
),
1,
1,
''
)
) As Consummator
From
Pm_TaskAllocation ta
Left Join Sys_Department d On ta.DepId = d.Id
Left Join Grp_DelegationInfo di On ta.DiId = di.Id
Left Join Sys_Users u On ta.CreateUserId = u.Id
Where
ta.IsDel = 0 {0}
) As temp
WHERE
[CreateUserName] like '%{1}%'
OR [Participant] like '%{2}%' ", whereSql, currUserName, currUserName);
RefAsync<int> total = 0;
var _view = await _sqlSugar.SqlQueryable<TaskListView>(pageSql)
.WhereIF(groupArr.Any(), x => groupArr.Contains(x.TeamName))
.ToPageListAsync(dto.PageIndex, dto.PageSize, total);//ToPageAsync
List<int> taskIds = new List<int>();
taskIds = _view.Select(it => it.Id).ToList();
string taskerSql = string.Format(@"Select tau.TAId,tau.Id,tau.UserId,u.CnName As UserName,tau.BeginTime,tau.OverTime,tau.TaskStatus,
tau.Cause,tau.Score,tau.Remark As ScoreRemark,tau.CreateUserId As TaskCreateUserId
From Pm_TaskRelevanceUser tau
Left Join Sys_Users u On tau.UserId = u.Id
Where tau.IsDel = 0");
var taskerData = _sqlSugar.SqlQueryable<TaskerDetailsView>(taskerSql).Where(it => taskIds.Contains(it.TAId)).ToList();
foreach (var item in _view)
{
//任务接收者显示自己任务状态
if (!item.CreateUserName.Equals(currUserName))
{
var subTaskInfo = taskerData.FirstOrDefault(x => item.Id == x.TAId && x.UserId == dto.UserId);
if (subTaskInfo != null) item.Status = subTaskInfo.TaskStatus;
}
else
{
item.TaskerDetails = taskerData.Where(it => it.TAId == item.Id).ToArray();
}
////处理任务总状态 And 任务人状态
//var taskerStatusData = taskerData.Where(it => it.TAId == item.Id && it.TaskCreateUserId != dto.UserId && it.UserId == dto.UserId).FirstOrDefault();
//if (taskerStatusData != null)
//{
// item.Status = taskerStatusData.TaskStatus;
//}
}
return Ok(JsonView(true, "查询成功!", _view, total));
}
/// <summary>
/// 任务分配
/// 详情
/// </summary>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> PostTaskAllocationDetails(TaskAllocationDetailsDto dto)
{
#region 参数验证
if (dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
if (dto.PageId < 1) dto.PageId = 172; //任务指派Id
PageFunAuthViewBase pageFunAuthView = new PageFunAuthViewBase();
#region 页面操作权限验证
pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(dto.UserId, dto.PageId);
if (pageFunAuthView.CheckAuth == 0) return Ok(JsonView(false, "您没有查看权限!"));
#endregion
#endregion
var _view = await _taskAllocationRep._Details(dto.PortType, dto.Id);
if (_view.Code == 0)
{
return Ok(JsonView(true, "查询成功!", _view.Data));
}
return Ok(JsonView(false, _view.Msg));
}
/// <summary>
/// 任务分配
/// Add Or Edit
/// </summary>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> PostTaskAllocationAddOrEdit(TaskAllocationAddOrEditDto dto)
{
#region 参数验证
if (dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
if (dto.PageId < 1) dto.PageId = 172; //任务指派Id
PageFunAuthViewBase pageFunAuthView = new PageFunAuthViewBase();
#region 页面操作权限验证
pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(dto.UserId, dto.PageId);
if (dto.Id == 0)
{
if (pageFunAuthView.AddAuth == 0) return Ok(JsonView(false, "您没有添加权限!"));
}
else if (dto.Id > 0)
{
if (pageFunAuthView.EditAuth == 0) return Ok(JsonView(false, "您没有编辑权限!"));
}
#endregion
#endregion
var _view = await _taskAllocationRep._AddOrEdit(dto);
if (_view.Code == 0)
{
if (dto.Id == 0) //添加提示任务单创建
{
string title = $"[{dto.TaskName}] 任务新建成功!";
string content = $"[{dto.TaskName}] 任务新建成功,请前往任务页面查看详情!";
await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title, content, dto.UserIds);
var userIds = dto.UserIds.Select(x => x.ToString()).ToList();
await AppNoticeLibrary.SendUserMsg_Task_ToUser(userIds, dto.DiId, title, dto.UserId);
}
return Ok(JsonView(true, "操作成功!"));
}
return Ok(JsonView(false, _view.Msg));
}
/// <summary>
/// 任务分配
/// 状态任务归属人详情
/// </summary>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> PostTaskAllocationTaskerDetails(TaskerDetailsDto dto)
{
var _view = await _taskAllocationRep._TaskerDetails(dto.Id);
if (_view.Code == 0)
{
return Ok(JsonView(true, "操作成功!", _view.Data));
}
return Ok(JsonView(false, _view.Msg));
}
/// <summary>
/// 任务分配
/// 状态任务归属人设置开始状态
/// </summary>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> PostTaskAllocationSetStartStatus(TaskerStatusDto dto)
{
var _view = await _taskAllocationRep._TaskerSetStartStatus(dto.UserId, dto.Id);
if (_view.Code == 0)
{
//发送消息
var taskData = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskAllocation>().Where(it => it.Id == dto.Id).First();
if (taskData != null)
{
var taskUserIds = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskRelevanceUser>().Where(it => it.TAId == dto.Id).Select(it => it.UserId).ToList();
if (taskUserIds.Count > 0)
{
taskUserIds.Remove(dto.UserId);
}
var UserName = _taskAllocationRep._sqlSugar.Queryable<Sys_Users>().Where(it => it.Id == dto.UserId).Select(it => it.CnName).First();
string title_createUser = $"[{taskData.TaskName}] 进度更新!";
string conten_createUser = $"[{UserName}] 已开始任务,请注意该工作人员任务进度!";
//创建人发送消息
List<int> createUserIds = new List<int>() { taskData.CreateUserId };
await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title_createUser, conten_createUser, createUserIds);
await AppNoticeLibrary.SendUserMsg_Task_ToUser(createUserIds.Select(x => x.ToString()).ToList(), taskData.DiId, conten_createUser, taskData.CreateUserId);
//其他人发送消息
string title = $"[{taskData.TaskName}] 进度更新!";
string content = $"[{UserName}] 已开始任务.若需查看,请前往任务页面查看详情!";
await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title, content, taskUserIds);
await AppNoticeLibrary.SendUserMsg_Task_ToUser(taskUserIds.Select(x => x.ToString()).ToList(), taskData.DiId, content, dto.UserId);
}
return Ok(JsonView(true, "操作成功!"));
}
return Ok(JsonView(false, _view.Msg));
}
/// <summary>
/// 任务分配
/// 状态 任务归属人 设置完成状态
/// </summary>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> PostTaskAllocationSetOverStatus(TaskerStatusDto dto)
{
var _view = await _taskAllocationRep._TaskerSetOverStatus(dto.UserId, dto.Id);
if (_view.Code == 0)
{
//发送消息
var taskData = _sqlSugar.Queryable<Pm_TaskAllocation>().Where(it => it.Id == dto.Id).First();
if (taskData != null)
{
var taskUserIds =_sqlSugar.Queryable<Pm_TaskRelevanceUser>().Where(it => it.TAId == dto.Id).Select(it => it.UserId).Distinct().ToList();
var UserName = _sqlSugar.Queryable<Sys_Users>().Where(it => it.Id == dto.UserId).Select(it => it.CnName).First();
string title_createUser = $"[{taskData.TaskName}] 进度更新!";
string conten_createUser = $"[{UserName}] 已完成任务,请前往任务页面进行审核操作!";
await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title_createUser, conten_createUser, new List<int>() { taskData.CreateUserId }); //创建人发送消息
await AppNoticeLibrary.SendUserMsg_Task_ToUser(new List<string>() { taskData.CreateUserId.ToString() }, taskData.DiId, conten_createUser, dto.UserId);
string title = $"[{taskData.TaskName}] 进度更新!";
string content = $"[{UserName}] 已完成任务,请注意在规定时间内完成任务.若需查看,请前往任务页面查看详情!";
string yw_content = $"[{UserName}] 已完成任务,请注意在规定时间内完成任务!";
await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title, content, taskUserIds); //其他人发送消息
await AppNoticeLibrary.SendUserMsg_Task_ToUser(taskUserIds.Select(x => x.ToString()).ToList(), taskData.DiId, yw_content, dto.UserId);
string content1 = $"任务已完成,等待任务发布人审核！若需查看,请前往任务页面查看详情!";
string yw_content1 = $"任务已完成,等待任务发布人审核!";
await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title, content1, new List<int>() { dto.UserId }); //设置任务人 发送消息
await AppNoticeLibrary.SendUserMsg_Task_ToUser(new List<string>() { dto.UserId.ToString() }, taskData.DiId, yw_content1, dto.UserId);
}
return Ok(JsonView(true, "操作成功!"));
}
return Ok(JsonView(false, _view.Msg));
}
/// <summary>
/// 任务分配
/// 状态 任务归属人 设置知晓状态
/// </summary>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> PostTaskAllocationSetHaveStatus(TaskAllocationStatusDto dto)
{
var _view = await _taskAllocationRep._TaskSetHaveStatus(dto.SubId);
if (_view.Code == 0)
{
//发送消息
var taskUserData = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskRelevanceUser>().Where(it => it.Id == dto.SubId).First();
if (taskUserData != null)
{
var taskData = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskAllocation>().Where(it => it.Id == taskUserData.TAId).First();
if (taskData != null)
{
var UserName = _taskAllocationRep._sqlSugar.Queryable<Sys_Users>().Where(it => it.Id == taskData.CreateUserId).Select(it => it.CnName).First();
string title = $"[{taskData.TaskName}] 进度更新!";
string conten_createUser = $"[{UserName}] 已知晓任务.若需查看,请前往任务页面查看详情!";
string qw_conten_createUser = $"[{UserName}] 已知晓任务!";
await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title, conten_createUser, new List<int>() { taskData.CreateUserId }); //创建人发送消息
await AppNoticeLibrary.SendUserMsg_Task_ToUser(new List<string>() { taskData.CreateUserId.ToString() }, taskData.DiId, qw_conten_createUser, taskData.CreateUserId);
string content = $"请注意任务完成时间！若需查看,请前往任务页面查看详情!";
string yw_content = $"请注意任务完成时间!";
await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title, content, new List<int>() { taskUserData.UserId }); //设置任务人 发送消息
await AppNoticeLibrary.SendUserMsg_Task_ToUser(new List<string>() { taskUserData.UserId.ToString() }, taskData.DiId, yw_content, taskUserData.UserId);
}
}
return Ok(JsonView(true, "操作成功!"));
}
return Ok(JsonView(false, _view.Msg));
}
/// <summary>
/// 任务分配
/// 任务发布者 单人设置审批状态
/// </summary>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> PostTaskAllocationSetAuditStatus(TaskAllocationStatusDto dto)
{
var _view = await _taskAllocationRep._TaskSetAuditStatus(dto.SubId);
if (_view.Code == 0)
{
//发送消息
var taskUserData = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskRelevanceUser>().Where(it => it.Id == dto.SubId).First();
if (taskUserData != null)
{
var taskData = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskAllocation>().Where(it => it.Id == taskUserData.TAId).First();
if (taskData != null)
{
string title = $"[{taskData.TaskName}] 进度更新!";
string content = $"任务已完成！若需查看,请前往任务页面查看详情!";
string yw_content = $"任务已完成!";
await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title, content, new List<int>() { taskUserData.UserId }); //设置任务人 发送消息
await AppNoticeLibrary.SendUserMsg_Task_ToUser(new List<string>() { taskUserData.UserId.ToString() }, taskData.DiId, yw_content, taskUserData.UserId);
}
}
return Ok(JsonView(true, "操作成功!"));
}
return Ok(JsonView(false, _view.Msg));
}
/// <summary>
/// 任务分配
/// 任务发布者 单人设置未完成状态
/// </summary>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> PostTaskAllocationSetUnFinishedStatus(TaskAllocationSetUnFinishedStatusDto dto)
{
var _view = await _taskAllocationRep._TaskSetUnFinishedStatus(dto.SubId, dto.Cause);
if (_view.Code == 0)
{
//发送消息
var taskUserData = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskRelevanceUser>().Where(it => it.Id == dto.SubId).First();
if (taskUserData != null)
{
var taskData = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskAllocation>().Where(it => it.Id == taskUserData.TAId).First();
if (taskData != null)
{
string title = $"[{taskData.TaskName}] 进度更新!";
string content = $"任务未完成！若需查看,请前往任务页面查看详情!";
string yw_content = $"任务未完成!";
await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title, content, new List<int>() { taskUserData.UserId }); //设置任务人 发送消息
await AppNoticeLibrary.SendUserMsg_Task_ToUser(new List<string>() { taskUserData.UserId.ToString() }, taskData.DiId, yw_content, taskUserData.UserId);
}
}
return Ok(JsonView(true, "操作成功!"));
}
return Ok(JsonView(false, _view.Msg));
}
///// <summary>
///// 任务分配
///// 确认任务是否可操作完成
///// </summary>
///// <returns></returns>
//[HttpPost]
//[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
//public async Task<IActionResult> PostTaskAllocationIsConfirmCompletion(TaskAllocationScoreDto dto)
//{
// try
// {
// #region 参数验证
// if (dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
// if (dto.PageId < 1) dto.PageId = 172; //任务指派Id
// PageFunAuthViewBase pageFunAuthView = new PageFunAuthViewBase();
// #region 页面操作权限验证
// pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(dto.UserId, dto.PageId);
// if (pageFunAuthView.EditAuth == 0) return Ok(JsonView(false, "您没有编辑权限!"));
// #endregion
// #endregion
// var _view = await _taskAllocationRep._TaskConfirmCompletion(dto.PortType, dto.Id);
// if (_view.Code == 0)
// {
// return Ok(JsonView(true, "操作成功!"));
// }
// return Ok(JsonView(false, _view.Msg));
// }
// catch (Exception ex)
// {
// return Ok(JsonView(false, ex.Message));
// }
//}
///// <summary>
///// 任务分配
///// 任务确认完成
///// </summary>
///// <returns></returns>
//[HttpPost]
//[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
//public async Task<IActionResult> PostTaskAllocationConfirmCompletion(TaskAllocationConfirmCompletionDto dto)
//{
// try
// {
// #region 参数验证
// if (dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
// if (dto.PageId < 1) dto.PageId = 172; //任务指派Id
// PageFunAuthViewBase pageFunAuthView = new PageFunAuthViewBase();
// #region 页面操作权限验证
// pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(dto.UserId, dto.PageId);
// if (pageFunAuthView.EditAuth == 0) return Ok(JsonView(false, "您没有编辑权限!"));
// #endregion
// #endregion
// var _view = await _taskAllocationRep._TaskConfirmCompletion(dto.PortType,dto.Id);
// if (_view.Code == 0)
// {
// return Ok(JsonView(true, "操作成功!"));
// }
// return Ok(JsonView(false, _view.Msg));
// }
// catch (Exception ex)
// {
// return Ok(JsonView(false, ex.Message));
// }
//}
/// <summary>
/// 任务分配
/// 任务发布者 任务评分
/// </summary>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> PostTaskAllocationScore(TaskAllocationScoreDto dto)
{
#region 参数验证
if (dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
if (dto.PageId < 1) dto.PageId = 172; //任务指派Id
PageFunAuthViewBase pageFunAuthView = new PageFunAuthViewBase();
#region 页面操作权限验证
pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(dto.UserId, dto.PageId);
if (pageFunAuthView.EditAuth == 0) return Ok(JsonView(false, "您没有编辑权限!"));
#endregion
#endregion
var _view = await _taskAllocationRep._TaskScore(dto);
if (_view.Code == 0)
{
//发送消息
var taskUserData = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskRelevanceUser>().Where(it => it.Id == dto.SubId).First();
if (taskUserData != null)
{
var taskData = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskAllocation>().Where(it => it.Id == taskUserData.TAId).First();
if (taskData != null)
{
string title = $"[{taskData.TaskName}] 进度更新!";
string content = $"任务评分已完成！若需查看,请前往任务页面查看详情!";
string yw_content = $"任务评分已完成!";
await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title, content, new List<int>() { taskUserData.UserId }); //设置任务人 发送消息
await AppNoticeLibrary.SendUserMsg_Task_ToUser(new List<string>() { taskUserData.UserId.ToString() }, taskData.DiId, yw_content, taskUserData.UserId);
}
}
return Ok(JsonView(true, "操作成功!"));
}
return Ok(JsonView(false, _view.Msg));
}
/// <summary>
/// 任务分配
/// 任务发布者 任务终止
/// </summary>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> PostTaskAllocationTermination(TaskAllocationConfirmCompletionDto dto)
{
#region 参数验证
if (dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
if (dto.PageId < 1) dto.PageId = 172; //任务指派Id
PageFunAuthViewBase pageFunAuthView = new PageFunAuthViewBase();
#region 页面操作权限验证
pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(dto.UserId, dto.PageId);
if (pageFunAuthView.EditAuth == 0) return Ok(JsonView(false, "您没有编辑权限!"));
#endregion
#endregion
var _view = await _taskAllocationRep._TaskTermination(dto.Id);
if (_view.Code == 0)
{
//发送消息
var taskData = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskAllocation>().Where(it => it.Id == dto.Id).First();
if (taskData != null)
{
var taskUserIds = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskRelevanceUser>().Where(it => it.Id == dto.Id).Select(it => it.UserId).ToList();
taskUserIds.Add(taskData.CreateUserId);
string title = $"[{taskData.TaskName}] 进度更新!";
string content = $"任务已终止！若需查看,请前往任务页面查看详情!";
string yw_content = $"[{taskData.TaskName}]任务已终止!";
await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title, content, taskUserIds); //设置任务人 发送消息
await AppNoticeLibrary.SendUserMsg_Task_ToUser(taskUserIds.Select(x => x.ToString()).ToList(), taskData.DiId, yw_content, taskData.CreateUserId);
}
return Ok(JsonView(true, "操作成功!"));
}
return Ok(JsonView(false, _view.Msg));
}
/// <summary>
/// 任务分配
/// 任务发布者 任务删除
/// </summary>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> PostTaskAllocationDel(TaskAllocationConfirmCompletionDto dto)
{
#region 参数验证
if (dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
if (dto.PageId < 1) dto.PageId = 172; //任务指派Id
PageFunAuthViewBase pageFunAuthView = new PageFunAuthViewBase();
#region 页面操作权限验证
pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(dto.UserId, dto.PageId);
if (pageFunAuthView.DeleteAuth == 0) return Ok(JsonView(false, "您没有删除权限!"));
#endregion
#endregion
var _view = await _taskAllocationRep._TaskDel(dto.Id);
if (_view.Code == 0)
{
return Ok(JsonView(true, "操作成功!"));
}
return Ok(JsonView(false, _view.Msg));
}
#endregion
#region 团组状态通知
/// <summary>
/// 测试
/// </summary>
/// <param name="dto"></param>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> Test_QIYEWX(PostTourClientListDownloadFile dto)
{
//List<string> templist = new List<string>() { 234.ToString() };
//await AppNoticeLibrary.SendUserMsg_GroupStatus_AuditFee(14090, templist, QiyeWeChatEnum.TestChat);
//await AppNoticeLibrary.SendUserMsg_GroupShare_ToJob(dto.DiId); ;
//DeleReminderMessage.PostMessageByWebhook();
//GroupStatus_UserSimplelistView list = await _qiYeWeChatApiService.GroupStatus_GetUserList();
//创建群聊
//List<string> userList1 = new List<string>() { "Feint", "amy.zhu@pan-american-intl.com", "judy.zeng@pan-american-intl.com", "FuHongJin" };
//List<string> userList2 = new List<string>() { "Feint", "ZhaoYaQi", "LiaoWenYa" };
//List<string> userList3 = new List<string>() { "Feint", "amy.zhu@pan-american-intl.com", "judy.zeng@pan-american-intl.com", "FuHongJin", "ZhaoYaQi", "LiaoWenYa" };
//GroupStatus_CreateChatView rst1 = await _qiYeWeChatApiService.GroupStatus_CreateChat("团组通知", "Feint", userList1, "CaiWuChat01");
//GroupStatus_CreateChatView rst2 = await _qiYeWeChatApiService.GroupStatus_CreateChat("OA通知-国交部", "Feint", userList2, "GuoJiaoLeader01");
//GroupStatus_CreateChatView rst3 = await _qiYeWeChatApiService.GroupStatus_CreateChat("OA通知-团组(公司客户)", "Feint", userList3, "CompanyCRMChat01");
//推送消息(模板)
//List<string> userList = new List<string>() { "Feint", "huaju.liu", "johnny.yang@pan-american-intl.com" };
//List<string> userList = new List<string>() { "Feint", "johnny.yang@pan-american-intl.com" };
//GroupStatus_CreateChatView rst1 = await _qiYeWeChatApiService.GroupStatus_CreateChat("团组费用提示", "Feint", userList, "GuoJiaoChat01");
//团组出发
//AppNoticeLibrary.SendUserMsg_GroupStatus_Create(2358, userList);
//费用审核
//AppNoticeLibrary.SendChatMsg_GroupStatus_ApplyFee(dto.DiId, QiyeWeChatEnum.TestChat);
//费用审核结果通知（通过情况下发送财务群）
//List<string> userList = new List<string>() { "234" };
//AppNoticeLibrary.SendUserMsg_GroupStatus_AuditFee(dto.DiId, userList, QiyeWeChatEnum.CaiWuChat02);
//4、财务付款时:(1)对应版块人员【单独发,状态为已付款才发】
//AppNoticeLibrary.SendUserMsg_GroupStatus_PayResult(dto.DiId, userList);
//团组提醒财务群
//DateTime dtNow = DateTime.Now;
//List<Grp_DelegationInfo> listSource = _usersRep.Query<Grp_DelegationInfo>(s => s.IsDel == 0 && s.VisitStartDate >= dtNow).Take(3).ToList();
//List<Grp_DelegationInfo> listAdd7day = _usersRep.Query<Grp_DelegationInfo>(s => s.IsDel == 0 && s.VisitStartDate >= dtNow).Take(3).ToList();
//List<Grp_DelegationInfo> listAdd3day = new List<Grp_DelegationInfo>() { };
//AppNoticeLibrary.SendChatMsg_GroupRemindersToCaiwu(listAdd7day, listAdd3day, QiyeWeChatEnum.TestChat);
//日付申请提醒财务群
//AppNoticeLibrary.DailyPayReminders_Create_ToCaiwuChat(dto.DiId, QiyeWeChatEnum.CaiWuChat02);
//日付申请结果推送用户、成功通知财务群
//AppNoticeLibrary.DailyPayReminder_Audit_ToUser(dto.DiId, userList, QiyeWeChatEnum.TestChat);
//AppNoticeLibrary.DailyPayReminder_Pay_ToUser(dto.DiId, userList);
//string q = "";
DeleReminderMessage.PostMessageByWebhook_CRMStatistics();
return Ok(JsonView(true, "操作成功！"));
}
#endregion
#region 物资进销存
/// <summary>
/// 物资进销存
/// 基础数据类型
/// </summary>
/// <returns></returns>
[HttpGet]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> GoodsInitDataSource()
{
return Ok(await _goodsRep.InitDataSource());
}
/// <summary>
/// 物资进销存
/// 基础数据类型 --> 团组名称列表 分页
/// </summary>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> GoodsGroupNameInit(QueryGroupListOffsetDto dto)
{
var watch = new Stopwatch();
watch.Start();
var countyDatas = await _sqlSugar
.Queryable<Grp_DelegationInfo>()
.Where((di) => di.IsDel == 0 && !string.IsNullOrWhiteSpace(di.TeamName))
.OrderBy((di) => new { id = SqlFunc.Desc(di.Id) })
.Select((di) => new { id = di.Id, name = di.TeamName})
.ToListAsync();
countyDatas.Insert(0, new { id = 0, name = "其他物资(公司内部物资)"});
countyDatas.Insert(0, new { id = -1, name = "拜访客户所使用的物资" });
countyDatas.Insert(0, new { id = -2, name = "库存调整" });
var total = countyDatas.Count;
countyDatas = countyDatas.WhereIF(!string.IsNullOrEmpty(dto.Search), x => x.name.Contains(dto.Search)).ToList();
countyDatas = countyDatas
.Skip((dto.PageIndex - 1) * dto.PageSize)
.Take(dto.PageSize)
.ToList();
watch.Stop();
return Ok(JsonView(true, $"{MsgTips.Succeed}，耗时 {watch.ElapsedMilliseconds} ms", countyDatas, total));
}
/// <summary>
/// 物资进销存
/// 物品 列表
/// </summary>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> GoodsList(GoodsListDto dto)
{
if (dto.PortType < 1 || dto.PortType > 3) return Ok(JsonView(false, MsgTips.Port));
if (dto.PageIndex < 1 || dto.PageSize < 1) return Ok(JsonView(false, MsgTips.PageIndex));
return Ok(await _goodsRep.GoodsList(dto));
}
/// <summary>
/// 物资进销存
/// 物品 详情
/// </summary>
/// <returns></returns>
[HttpGet()]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> GoodsInfo(int portType, int id)
{
if (portType < 1 || portType > 3) return Ok(JsonView(false, MsgTips.Port));
if (id < 1) return Ok(JsonView(false, MsgTips.Id));
return Ok(await _goodsRep.GoodsInfo(portType, id));
}
/// <summary>
/// 物资进销存
/// 物品 OP(Add OR Edit)
/// </summary>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> GoodsOP(GoodsOpDto dto)
{
var currUserInfo = JwtHelper.SerializeJwt(HttpContext.Request.Headers.Authorization);
if (currUserInfo == null) return Ok(JsonView(false, "请传入token!"));
var validator = new GoodsOPDTOValidator();
var validatorRes = await validator.ValidateAsync(dto);
if (!validatorRes.IsValid)
{
var sb = new StringBuilder();
foreach (var error in validatorRes.Errors) sb.AppendLine(error.ErrorMessage);
return Ok(JsonView(false, sb.ToString()));
}
return Ok(await _goodsRep.GoodsOp(dto, currUserInfo.UserId));
}
/// <summary>
/// 物资进销存
/// 物品 Del
/// </summary>
/// <returns></returns>
[HttpDelete("{id}")]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> GoodsDel(int id)
{
if (id < 1) return Ok(JsonView(false, MsgTips.Id));
var currUserInfo = JwtHelper.SerializeJwt(HttpContext.Request.Headers.Authorization);
if (currUserInfo == null) return Ok(JsonView(false, "请传入token!"));
return Ok(await _goodsRep.GoodsDel(id, currUserInfo.UserId));
}
/// <summary>
/// 物资进销存
/// 入库 列表
/// </summary>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> GoodsStorageList(GoodsStorageListDto dto)
{
if (dto.PortType < 1 || dto.PortType > 3) return Ok(JsonView(false, MsgTips.Port));
if (dto.PageIndex < 1 || dto.PageSize < 1) return Ok(JsonView(false, MsgTips.PageIndex));
return Ok(await _goodsRep.GoodsStorageList(dto));
}
/// <summary>
/// 物资进销存
/// 入库 详情
/// </summary>
/// <returns></returns>
[HttpGet("{id}")]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> GoodsStorageInfo([FromQuery] int portType, int id)
{
if (portType < 1 || portType > 3) return Ok(JsonView(false, MsgTips.Port));
if (id < 1) return Ok(JsonView(false, MsgTips.Id));
return Ok(await _goodsRep.GoodsStorageInfo(portType, id));
}
/// <summary>
/// 物资进销存
/// 入库 OP(Add OR Edit)
/// </summary>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> GoodsStorageOp(GoodsStorageOpDto dto)
{
var currUserInfo = JwtHelper.SerializeJwt(HttpContext.Request.Headers.Authorization);
if (currUserInfo == null) return Ok(JsonView(false, "请传入token!"));
var validator = new GoodsStorageOpDtoValidator();
var validatorRes = await validator.ValidateAsync(dto);
if (!validatorRes.IsValid)
{
var sb = new StringBuilder();
foreach (var error in validatorRes.Errors) sb.AppendLine(error.ErrorMessage);
return Ok(JsonView(false, sb.ToString()));
}
return Ok(await _goodsRep.GoodsStorageOp(dto, currUserInfo.UserId));
}
/// <summary>
/// 物资进销存
/// 入库 Del
/// </summary>
/// <returns></returns>
[HttpDelete("{id}")]
//[Authorize]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> GoodsStorageDel(int id)
{
var currUserInfo = JwtHelper.SerializeJwt(HttpContext.Request.Headers.Authorization);
if (currUserInfo == null) return Ok(JsonView(false, "请传入token!"));
if (id < 1) return Ok(JsonView(false, MsgTips.Id));
return Ok(await _goodsRep.GoodsStorageDel(id, currUserInfo.UserId));
}
/// <summary>
/// 物资进销存
/// 入库 excelDownload
/// </summary>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> GoodsStorageExcelDownload()
{
//token验证
var currUserInfo = JwtHelper.SerializeJwt(HttpContext.Request.Headers.Authorization);
if (currUserInfo == null) return Ok(JsonView(false, "请传入token!"));
//文件下载权限验证
int userId = currUserInfo.UserId,
pageId = 191;
PageFunAuthViewBase pageFunAuthView = new PageFunAuthViewBase();
#region 页面操作权限验证
pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(userId, pageId);
if (pageFunAuthView.FilesDownloadAuth == 0) return Ok(JsonView(false, "您未分配文件下载权限!"));
#endregion
return Ok(await _goodsRep.GoodsStorageExcelDownload());
}
/// <summary>
/// 物资进销存
/// 领用 List
/// </summary>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> GoodsReceiveList(GoodsReceiveListDTO dto)
{
//token验证
var currUserInfo = JwtHelper.SerializeJwt(HttpContext.Request.Headers.Authorization);
if (currUserInfo == null) return Ok(JsonView(false, "请传入token!"));
if (dto.PortType < 1 || dto.PortType > 3) return Ok(JsonView(false, MsgTips.Port));
if (dto.PageIndex < 1 || dto.PageSize < 1) return Ok(JsonView(false, MsgTips.PageIndex));
//文件下载权限验证
int userId = currUserInfo.UserId,
pageId = 191;
if (dto.IsExcelDownload )
{
if (userId < 1) return Ok(JsonView(false, "excel导出时,需传入正确的当前操作人UserId!"));
PageFunAuthViewBase pageFunAuthView = new PageFunAuthViewBase();
#region 页面操作权限验证
pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(userId,pageId);
if (pageFunAuthView.FilesDownloadAuth == 0) return Ok(JsonView(false, "您未分配文件下载权限!"));
#endregion
}
return Ok(await _goodsRep.GoodsReceiveList(dto));
}
/// <summary>
/// 物资进销存
/// 领用详情
/// </summary>
/// <returns></returns>
[HttpGet("{id}")]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> GoodsReceiveInfo([FromQuery] int portType, int id)
{
if (portType < 1 || portType > 3) return Ok(JsonView(false, MsgTips.Port));
if (id < 1) return Ok(JsonView(false, MsgTips.Id));
return Ok(await _goodsRep.GoodsReceiveInfo(portType, id));
}
/// <summary>
/// 物资进销存
/// 领用 OP
/// </summary>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> GoodsReceiveOP(GoodsReceiveOpDto dto)
{
var currUserInfo = JwtHelper.SerializeJwt(HttpContext.Request.Headers.Authorization);
if (currUserInfo == null) return Ok(JsonView(false, "请传入token!"));
var validator = new GoodsReceiveOpDtoValidator();
var validatorRes = await validator.ValidateAsync(dto);
if (!validatorRes.IsValid)
{
var sb = new StringBuilder();
foreach (var error in validatorRes.Errors) sb.AppendLine(error.ErrorMessage);
return Ok(JsonView(false, sb.ToString()));
}
return Ok(await _goodsRep.GoodsReceiveOp(dto, currUserInfo.UserId));
}
/// <summary>
/// 物资进销存
/// 领用 审核
/// </summary>
/// <param name="dto"></param>
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> GoodsReceiveAudit(GoodsReceiveAuditDTO dto)
{
var currUserInfo = JwtHelper.SerializeJwt(HttpContext.Request.Headers.Authorization);
if (currUserInfo == null) return Ok(JsonView(false, "请传入token!"));
var validator = new GoodsReceiveAuditDTOValidator();
var validatorRes = await validator.ValidateAsync(dto);
if (!validatorRes.IsValid)
{
var sb = new StringBuilder();
foreach (var error in validatorRes.Errors) sb.AppendLine(error.ErrorMessage);
return Ok(JsonView(false, sb.ToString()));
}
int[] idArray = dto.Label
.Split(',')
.Select(x =>
{
if (int.TryParse(x, out var id)) return id;
return id;
})
.ToArray();
return Ok(await _goodsRep.GoodsReceiveAudit(idArray, currUserInfo.UserId, dto.AuditEnum));
}
/// <summary>
/// 物资进销存
/// 领用 Del
/// </summary>
/// <returns></returns>
[HttpDelete("{id}")]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task<IActionResult> GoodsReceiveDel(int id)
{
var currUserInfo = JwtHelper.SerializeJwt(HttpContext.Request.Headers.Authorization);
if (currUserInfo == null) return Ok(JsonView(false, "请传入token!"));
if (id < 1) return Ok(JsonView(false, MsgTips.Id));
return Ok(await _goodsRep.GoodsReceiveDel(id, currUserInfo.UserId));
}
#endregion
#region 员工绩效
/// <summary>
/// 员工绩效组成结构获取
/// </summary>
/// <param name="userid"></param>
/// <param name="date"></param>
/// <param name="loginUser"></param>
/// <returns></returns>
[HttpGet]
public IActionResult GetPerformanceList(int userid,string date, int loginUser)
{
var jw = JsonView(false);
if (!DateTime.TryParse(date,out DateTime date_Dt))
{
jw.Msg = "日期格式有误!";
return Ok(jw);
}
string sql_CTE = $@"-- 定义递归查询的CTE
WITH PerAssessmentSettingsCTE AS (
-- 选择指定ID的记录作为起点
SELECT
pac.Id,
pac.Name,
pac.AssessmentProportion,
pac.AssessmentStandard,
pac.ParentId,
1 AS Depth
FROM
Per_AssessmentSetting pac
INNER JOIN
Per_AssessmentContentSetting pacs
ON
pac.id = pacs.assessmentSettingid AND pacs.isdel = 0
WHERE
pacs.userid = {userid}
AND
pac.isdel = 0
UNION ALL
-- 递归部分，选择所有子级记录
SELECT
ps.Id,
ps.Name,
ps.AssessmentProportion,
ps.AssessmentStandard,
ps.ParentId,
CAST(caste.Depth as int) + 1
FROM
Per_AssessmentSetting ps
INNER JOIN PerAssessmentSettingsCTE caste ON ps.Id = caste.ParentId)
-- 从CTE中选择最终结果
SELECT * FROM PerAssessmentSettingsCTE
OPTION (MAXRECURSION 0); -- 允许无限递归 ";
var result_CTE = _sqlSugar.Ado.SqlQuery<Per_AssessmentSetting>(sql_CTE);
var ids = result_CTE.Select(x => x.Id);
var List = _sqlSugar.Queryable<Per_AssessmentSetting>()
.LeftJoin<Per_AssessmentContentSetting>((a, b) => a.Id == b.AssessmentSettingId && b.IsDel == 0 && b.UserId == userid)
.LeftJoin<Per_AssessmentScore>((a, b,c) => b.Id == c.AssessmentContentSettingId && c.IsDel == 0 && c.YearMonth.Year == date_Dt.Year && c.YearMonth.Month == date_Dt.Month)
.Where((a, b) => a.IsDel == 0 && ids.Contains(a.Id))
.Select((a, b, c) => new TreeNode
{
Id = a.Id,
ContentId = b.Id,
Name = a.Name,
ParentId = a.ParentId,
AssessmentProportion = a.AssessmentProportion, //占比
AssessmentStandard = a.AssessmentStandard, //描述
AssessmentProportionChi = b.AssessmentProportionChi, //占比
UserId = b.UserId,
JobId = b.JobId,
AssessmentSettingId = b.AssessmentSettingId,
Fixed = b.Fixed,
TargetValue = b.TargetValue,
AssessmentProportion_Percentage = a.AssessmentProportion * 100,
HigherUpAssessment = c.HigherUpAssessment,
HigherUpConfig = c.HigherUpConfig,
HigherUpUserId = c.HigherUpUserId,
Score = c.Score,
ScoreTotal = c.ScoreTotal,
SelfAssessment = c.SelfAssessment,
Status = c.Status,
YearMonth = c.YearMonth,
})
.ToList();
var rootNodeList = List.Where(x => x.ParentId == 0);
var rootResult = rootNodeList.Select(x => BuildSubTree(x, List));
jw.Data = new
{
Root = rootResult,
IsLeader = IsLeader(userid,loginUser)
};
jw.Code = 200;
jw.Msg = "成功";
return Ok(jw);
}
private TreeNode BuildSubTree(TreeNode parent, List<TreeNode> nodes)
{
var children = nodes
.Where(n => n.ParentId == parent.Id)
.Select(n => BuildSubTree(n, nodes))
.ToList();
parent.Children = children;
return parent;
}
/// <summary>
/// 绩效项增改
/// </summary>
/// <param name="dto"></param>
/// <returns></returns>
[HttpPost]
public async Task<IActionResult> AssessmentSettingOperationAsync(PerAssessmentSettingOperationDto dto)
{
var jw = JsonView(false);
if (!ModelState.IsValid)
{
jw.Msg = "参数错误";
jw.Data = ModelState;
return Ok(jw);
}
try
{
if (dto.ParentId != 0)
{
var parent = await _sqlSugar.Queryable<Per_AssessmentSetting>().FirstAsync(x=>x.IsDel == 0 && x.Id == dto.ParentId);
if (parent == null)
{
jw.Msg = "父级节点不存在";
return Ok(jw);
}
}
var entity = new Per_AssessmentSetting
{
Name = dto.Name,
AssessmentProportion = dto.AssessmentProportion,
AssessmentStandard = dto.AssessmentStandard,
ParentId = dto.ParentId,
Id = dto.Id,
Remark = dto.Remark,
};
jw.Code = 200;
if (dto.Id == 0)
{
entity.CreateUserId = dto.CreateId;
entity.CreateTime = DateTime.Now;
await _sqlSugar.Insertable(entity).ExecuteCommandAsync();
jw.Msg = "添加成功!";
}
else
{
await _sqlSugar.Updateable(entity).ExecuteCommandAsync();
jw.Msg = "修改成功!";
}
}
catch (Exception ex)
{
jw.Msg = "Api error " + ex.Message;
jw.Code = 400;
}
return Ok(jw);
}
/// <summary>
/// 绩效内容增改
/// </summary>
/// <param name="dto"></param>
/// <returns></returns>
[HttpPost]
public IActionResult AssessmentSettingOperationContentAsync(AssessmentSettingOperationContenDto dto)
{
var jw = JsonView(false, "", "");
var entity = new Per_AssessmentContentSetting
{
AssessmentProportionChi = dto.AssessmentProportionChi,
AssessmentSettingId = dto.AssessmentSettingId,
CreateTime = DateTime.Now,
CreateUserId = dto.CreateUserId,
Fixed = dto.Fixed,
Id = dto.Id,
JobId = dto.JobId,
TargetValue = dto.TargetValue,
UserId = dto.UserId,
Remark = dto.Remark,
};
var entity_Fk = _sqlSugar.Queryable<Per_AssessmentSetting>().First(x => x.Id == dto.AssessmentSettingId && x.IsDel == 0);
if (entity_Fk == null)
{
jw.Msg = "考核设置不存在";
return Ok(jw);
}
try
{
if (dto.Id == 0)
{
//add
var insertCount = _sqlSugar.Insertable(entity).ExecuteCommand();
jw.Msg = "添加成功!";
}
else
{
//update
var updateCount = _sqlSugar.Updateable(entity).ExecuteCommand();
jw.Msg = "修改成功!";
}
jw.Code = 200;
}
catch (Exception ex)
{
jw.Msg = "Api error " + ex.Message;
jw.Code = 400;
}
return Ok(jw);
}
/// <summary>
/// 绩效项查询
/// </summary>
/// <param name="dto"></param>
/// <returns></returns>
[HttpPost]
public async Task<IActionResult> QueryAssessmentSettingListOffsetAsync(QueryAssessmentSettingListOffsetAsyncDto dto)
{
var jw = JsonView(false);
RefAsync<int> total = 0;//REF和OUT不支持异步,想要真的异步这是最优解
var entities = await _sqlSugar.Queryable<Per_AssessmentSetting>()
.Where(x=>x.IsDel == 0)
.WhereIF(!string.IsNullOrEmpty(dto.SearchValue), e => e.Name.Contains(dto.SearchValue))
.ToPageListAsync(dto.pageIndex, dto.pageSize, total);
var DtoResult = entities.Select(e => new
{
e.Id,
Name = e.Name,
AssessmentProportion = e.AssessmentProportion,
AssessmentStandard = e.AssessmentStandard,
ParentId = e.ParentId,
Remark = e.Remark
}).ToList();
jw.Data = new
{
total = total.Value,
dto.pageIndex,
dto.pageSize,
List = DtoResult
};
jw.Code = 200;
jw.Msg = "查询成功!";
return Ok(jw);
}
/// <summary>
/// 绩效分数保存
/// </summary>
/// <param name="dto"></param>
/// <returns></returns>
[HttpPost]
public IActionResult SaveUserAssessmen(SaveUserAssessmenDto dto)
{
var jw = JsonView(false,"请传入正确的数据！");
if (dto.Data.Any()) {
if (!DateTime.TryParse(dto.AssessmenData, out DateTime yearMonth_Dt))
{
jw.Data = "月份参数有误！";
return Ok(jw);
}
try
{
var ids = dto.Data.Select(x => x.AssessmentContentSettingId).ToList();
var QueryContent_DB = _sqlSugar.Queryable<Per_AssessmentContentSetting>()
.InnerJoin<Per_AssessmentSetting>((a, b) => b.IsDel == 0 && a.AssessmentSettingId == b.Id)
.Where((a, b) => a.IsDel == 0 && ids.Contains(a.Id))
.Select((a, b) => new
{
ContentSettingId = a.Id,
SettingId = b.Id,
a.TargetValue,
b.AssessmentStandard,
MergeStr = $"【项名称:{b.Name}/目标值:{a.TargetValue}/评估标准:{b.AssessmentStandard}】",
a.AssessmentProportionChi,
b.Name
})
.ToList()
.ToDictionary(x => x.ContentSettingId);
//删除上级未确认数据
var expressionWhere = Expressionable
.Create<Per_AssessmentScore>()
.And(x => x.YearMonth.Year == yearMonth_Dt.Year && x.YearMonth.Month == yearMonth_Dt.Month)
.And(x => ids.Contains(x.AssessmentContentSettingId))
.And(x => x.HigherUpConfig == 0)
.ToExpression();
if (IsLeader(dto.AssessmenUserId, dto.CreateUserId))
{
expressionWhere = Expressionable
.Create<Per_AssessmentScore>()
.And(x => x.YearMonth.Year == yearMonth_Dt.Year && x.YearMonth.Month == yearMonth_Dt.Month)
.And(x => ids.Contains(x.AssessmentContentSettingId))
.ToExpression();
}
_sqlSugar.BeginTran();
_sqlSugar.Updateable<Per_AssessmentScore>()
.Where(expressionWhere)
.SetColumns(x => new Per_AssessmentScore { IsDel = 1, DeleteUserId = dto.CreateUserId, DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") })
.ExecuteCommand();
var entityList = new List<Per_AssessmentScore>();
foreach (var x in dto.Data)
{
if (x.HigherUpAssessment > 100 || x.SelfAssessment > 100)
{
jw.Msg = QueryContent_DB[x.AssessmentContentSettingId].Name + "项分数不能超过100。";
return Ok(jw);
}
Per_AssessmentScore item = new Per_AssessmentScore
{
AssessmentContentSettingId = x.AssessmentContentSettingId,
CreateTime = DateTime.Now,
CreateUserId = dto.CreateUserId,
Details = QueryContent_DB[x.AssessmentContentSettingId].MergeStr,
HigherUpAssessment = x.HigherUpAssessment,
HigherUpUserId = x.LeadersId,
HigherUpConfig = x.HigherUpAssessment > 0 ? 1 : 0,
SelfAssessment = x.SelfAssessment,
IsDel = 0,
Status = x.Status,
YearMonth = yearMonth_Dt,
Score = x.SelfAssessment * 0.3M + x.HigherUpAssessment * 0.7M,
ScoreTotal = (x.SelfAssessment * 0.3M + x.HigherUpAssessment * 0.7M) * QueryContent_DB[x.AssessmentContentSettingId].AssessmentProportionChi,
};
entityList.Add(item);
}
var influenceRow = _sqlSugar.Insertable(entityList).ExecuteCommand();
_sqlSugar.CommitTran();
jw.Code = 200;
jw.Msg = "保存成功！";
jw.Data = $"{influenceRow}条数据操作成功！";
}
catch (Exception ex)
{
_sqlSugar.RollbackTran();
jw.Code = 500;
jw.Data = $"API ERROR ({ex.Message})";
}
}
return Ok(jw);
}
/// <summary>
/// 绩效项删除
/// </summary>
/// <param name="dto"></param>
/// <returns></returns>
[HttpPost]
public IActionResult DeleteAssessmentSetting(DeleteAssessmentSettingDto dto)
{
var jw = JsonView(false, "删除失败！");
if (!dto.IdArr.Any())
{
jw.Msg = "id不能为空!";
return Ok(jw);
}
var rowCount = _sqlSugar.Updateable<Per_AssessmentSetting>()
.Where(x => dto.IdArr.Contains(x.Id) && x.IsDel == 0)
.SetColumns(x => new Per_AssessmentSetting
{
IsDel = 1,
DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm"),
DeleteUserId = dto.UserId,
})
.ExecuteCommand();
jw.Code = 200;
jw.Msg = $"修改成功！,修改数量{rowCount}";
return Ok(jw);
}
/// <summary>
/// 绩效内容删除
/// </summary>
/// <param name="dto"></param>
/// <returns></returns>
[HttpPost]
public IActionResult DeleteAssessmentContentSetting(DeleteAssessmentSettingDto dto)
{
var jw = JsonView(false, "删除失败！");
if (!dto.IdArr.Any())
{
jw.Msg = "id不能为空!";
return Ok(jw);
}
var rowCount = _sqlSugar.Updateable<Per_AssessmentContentSetting>()
.Where(x => dto.IdArr.Contains(x.Id) && x.IsDel == 0)
.SetColumns(x => new Per_AssessmentContentSetting
{
IsDel = 1,
DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm"),
DeleteUserId = dto.UserId,
})
.ExecuteCommand();
jw.Code = 200;
jw.Msg = $"修改成功！,修改数量{rowCount}";
return Ok(jw);
}
private bool IsLeader(int userId, int higherUserId)
{
Dictionary <int,List<int>> keyValues = new Dictionary<int, List<int>>()
{
{ 5 , new List<int>{ 258 , 235, 234, 233, 208 } }
};
if (keyValues.ContainsKey(higherUserId))
{
return keyValues[higherUserId].Contains(userId);
}
return false;
}
#endregion
#region 企微Api测试
[HttpPost]
public async Task<IActionResult> GetCheckin_MonthDataAsync(DateTime start, DateTime end)
{
var jw = JsonView(false);
jw.Data = await _qiYeWeChatApiService.GetCheckin_MonthDataAsync1(start,end);
return Ok(jw);
}
[HttpPost]
public async Task<IActionResult> QueryAssessmentByUser(QueryAssessmentByUser Dto)
{
var jw = JsonView(false);
var user_entity = _sqlSugar.Queryable<Sys_Users>()
.First(e => e.Id == Dto.UserId && e.IsDel == 0);
var start_Bool = DateTime.TryParse(Dto.Start, out DateTime start);
var end_Bool = DateTime.TryParse(Dto.End, out DateTime end);
if (!start_Bool || !end_Bool)
{
jw.Msg = "时间格式不正确！";
return Ok(jw);
}
jw.Msg = "用户企业微信Id未绑定！";
if (user_entity != null && !string.IsNullOrEmpty(user_entity.QiyeChatUserId))
{
var data = await _qiYeWeChatApiService.QueryAssessmentByUser(start, end, new List<string> { user_entity.QiyeChatUserId });
jw.Data = data;
jw.Msg = "查询成功！";
jw.Code = 200;
}
return Ok(jw);
}
[HttpPost]
public IActionResult TempTest(QueryAssessmentSettingListOffsetAsyncDto Dto)
{
var jw = JsonView(false);
return Ok(jw);
}
#endregion
}
}