using Autofac.Diagnostics;
using Microsoft.AspNetCore.Mvc;
using Microsoft.AspNetCore.Mvc.RazorPages;
using OASystem.API.OAMethodLib;
using OASystem.API.OAMethodLib.QiYeWeChatAPI;
using OASystem.Domain;
using OASystem.Domain.Dtos.PersonnelModule;
using OASystem.Domain.Dtos.QiYeWeChat;
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 SqlSugar;
using StackExchange.Redis;
using System.Collections.Generic;
using System.Diagnostics;
using System.Globalization;
namespace OASystem.API.Controllers
{
///
/// 人事模块
///
[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;
///
/// 初始化
///
///
///
///
///
public PersonnelModuleController(IQiYeWeChatApiService qiYeWeChatApiService,WageSheetRepository wageSheetRep, UsersRepository usersRep, IMapper mapper)
{
_mapper = mapper;
_usersRep = usersRep;
_qiYeWeChatApiService = qiYeWeChatApiService;
_wageSheetRep = wageSheetRep;
_result = new Result();
}
#region 工资表单
///
/// 工资表单 基础数据源
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task GetWageSheetBasicsDataSource()
{
string companySql = string.Format("Select * From Sys_Company Where IsDel = 0");
var compnayData = await _wageSheetRep._sqlSugar.SqlQueryable(companySql).ToListAsync();
string depSql = string.Format("Select * From Sys_Department Where IsDel = 0");
var depData = await _wageSheetRep._sqlSugar.SqlQueryable(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));
}
///
/// 获取工资表单
///
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task 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));
}
///
/// 获取工资 详情
///
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task 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));
}
///
/// 人事模块 工资表单 删除
///
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task 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));
}
///
/// 人事模块 工资表单 添加 Or 修改
///
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task PostWageSheetAddOrEdit(WageAddOrEditDto dto)
{
try
{
_result = await _wageSheetRep.Post_WageSheet_AddOrEditAsync(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));
}
///
/// 计算工资
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task 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.AddDays(1); //
//本月工资是否有数据 有数据则不计算
result = await _wageSheetRep.Get_WageSheet_ListByYearMonthAsync(thisYearMonth);
if (result.Code == 0 )
{
return Ok(JsonView(false, thisYearMonth + " 工资数据已存在,若无人员工资请手动添加!"));
}
//获取上个月工资信息
List preWageSheetItems = await _wageSheetRep._sqlSugar.Queryable().Where(it => it.IsDel == 0 && it.YearMonth == preYearMonth).ToListAsync();
if (preWageSheetItems.Count <= 0)
{
return Ok(JsonView(false, thisYearMonth + " 上月工资数据不存在,请手动添加!"));
}
//处理上个月同月同人 多条数据
List preWageSheetItems1 = new List();
preWageSheetItems1 = preWageSheetItems.GroupBy(it => new { it.YearMonth,it.UserId })
.Select(it => it.FirstOrDefault(item => item.Basic !=0))
.ToList();
//获取OA系统内所有用户
var nameData = await _usersRep.GetUserNameList(1);
List? userNames = nameData.Data;
List wageSheets = new List();
_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 wageSheetItems = new List();
//wageSheetItems = _mapper.Map>(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"));
}
///
/// 计算工资 By YearMonth And UserId
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task 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 wageSheets = new List();
Pm_WageSheet wageSheet = _mapper.Map(dto);
wageSheets.Add(wageSheet);
//获取OA系统内所有用户
var nameData = await _usersRep.GetUserNameList(1);
List? userNames = nameData.Data;
_result = await PayrollComputation.SalaryCalculatorAsync(wageSheets, userNames, dto.UserId, dto.YearMonth, startDt, endDt.AddDays(1));
if (_result.Code != 0)
{
return Ok(JsonView(false, _result.Msg));
}
List wageSheets1 = new List();
wageSheets1 = _result.Data;
#region 处理返回数据
List wageSheetItems = new List();
wageSheetItems = _mapper.Map>(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]));
}
#endregion
}
}