PersonnelModuleController.cs 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386
  1. using Autofac.Diagnostics;
  2. using Microsoft.AspNetCore.Mvc;
  3. using Microsoft.AspNetCore.Mvc.RazorPages;
  4. using OASystem.API.OAMethodLib;
  5. using OASystem.API.OAMethodLib.QiYeWeChatAPI;
  6. using OASystem.Domain;
  7. using OASystem.Domain.Dtos.PersonnelModule;
  8. using OASystem.Domain.Dtos.QiYeWeChat;
  9. using OASystem.Domain.Entities.PersonnelModule;
  10. using OASystem.Domain.ViewModels.JuHeExchangeRate;
  11. using OASystem.Domain.ViewModels.PersonnelModule;
  12. using OASystem.Domain.ViewModels.QiYeWeChat;
  13. using OASystem.Infrastructure.Repositories.PersonnelModule;
  14. using SqlSugar;
  15. using StackExchange.Redis;
  16. using System.Collections.Generic;
  17. using System.Diagnostics;
  18. using System.Globalization;
  19. namespace OASystem.API.Controllers
  20. {
  21. /// <summary>
  22. /// 人事模块
  23. /// </summary>
  24. [Route("api/[controller]/[action]")]
  25. public class PersonnelModuleController : ControllerBase
  26. {
  27. private Result _result;
  28. private readonly IMapper _mapper;
  29. private readonly decimal _chengDuMinimumWage = 2100.00M;
  30. private readonly IQiYeWeChatApiService _qiYeWeChatApiService;
  31. private readonly WageSheetRepository _wageSheetRep;
  32. private readonly UsersRepository _usersRep;
  33. /// <summary>
  34. /// 初始化
  35. /// </summary>
  36. /// <param name="qiYeWeChatApiService"></param>
  37. /// <param name="wageSheetRep"></param>
  38. /// <param name="usersRep"></param>
  39. /// <param name="mapper"></param>
  40. public PersonnelModuleController(IQiYeWeChatApiService qiYeWeChatApiService,WageSheetRepository wageSheetRep, UsersRepository usersRep, IMapper mapper)
  41. {
  42. _mapper = mapper;
  43. _usersRep = usersRep;
  44. _qiYeWeChatApiService = qiYeWeChatApiService;
  45. _wageSheetRep = wageSheetRep;
  46. _result = new Result();
  47. }
  48. #region 工资表单
  49. /// <summary>
  50. /// 工资表单 基础数据源
  51. /// </summary>
  52. /// <returns></returns>
  53. [HttpPost]
  54. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  55. public async Task<IActionResult> GetWageSheetBasicsDataSource()
  56. {
  57. //获取OA系统内所有用户
  58. var nameData = await _usersRep.GetUserNameList(1);
  59. if (nameData.Code != 0)
  60. {
  61. return Ok(JsonView(false, nameData.Msg));
  62. }
  63. var data = new {
  64. userNames = nameData.Data
  65. };
  66. return Ok(JsonView(true, "查询成功!", data));
  67. }
  68. /// <summary>
  69. /// 获取工资表单
  70. /// </summary>
  71. /// <param name="dto"></param>
  72. /// <returns></returns>
  73. [HttpPost]
  74. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  75. public async Task<IActionResult> GetWageSheetList(WageSheetListDto dto)
  76. {
  77. //参数处理
  78. string ymFormat = "yyyy-MM";
  79. DateTime yearMonthDt;
  80. bool yearMonthDttIsValid = DateTime.TryParseExact(dto.YearMonth, ymFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out yearMonthDt);
  81. if (!yearMonthDttIsValid)
  82. {
  83. _result.Msg = "年月格式错误!正确时间格式:yyyy-MM ";
  84. return Ok(JsonView(false, _result.Msg));
  85. }
  86. //获取月工资数据
  87. string yearMonth = yearMonthDt.ToString("yyyy-MM");
  88. string startDt = yearMonthDt.AddDays(-1).ToString("yyyy-MM") + "-28",
  89. endDt = yearMonth + "-27";
  90. //应发合计 = 基本工资 +绩效工资 + 岗位津贴 + 员工的岗位津贴 + 服装洗理补贴 + 通讯补贴 + 交通补贴 + 保密费 + 操作奖金+ 其他补贴 + 部门集体团建费 + 代扣保险 + 代扣公积金 + 餐补
  91. //事假 病假 合计
  92. //扣款合计 = 迟到 + 早退 + 矿工 + 未打卡 + 其他扣款
  93. if (dto.PortType == 1)
  94. {
  95. _result = await _wageSheetRep.Get_WageSheet_ListByYearMonthAsync(yearMonth);
  96. if (_result.Code != 0)
  97. {
  98. return Ok(JsonView(false, _result.Msg));
  99. }
  100. }
  101. else if (dto.PortType == 2)
  102. { }
  103. else if (dto.PortType == 3)
  104. { }
  105. else
  106. {
  107. return Ok(JsonView(false, "请选择正确的端口参数"));
  108. }
  109. return Ok(JsonView(true, _result.Msg, _result.Data));
  110. }
  111. /// <summary>
  112. /// 获取工资 详情
  113. /// </summary>
  114. /// <param name="dto"></param>
  115. /// <returns></returns>
  116. [HttpPost]
  117. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  118. public async Task<IActionResult> GetWageSheetById(WageSheetInfoDto dto)
  119. {
  120. if (dto.PortType == 1)
  121. {
  122. _result = await _wageSheetRep.Get_WageSheet_InfoByIdAsync(dto.Id);
  123. if (_result.Code != 0)
  124. {
  125. return Ok(JsonView(false, _result.Msg));
  126. }
  127. }
  128. else if (dto.PortType == 2)
  129. { }
  130. else if (dto.PortType == 3)
  131. { }
  132. else
  133. {
  134. return Ok(JsonView(false, "请选择正确的端口参数"));
  135. }
  136. return Ok(JsonView(true, _result.Msg, _result.Data));
  137. }
  138. /// <summary>
  139. /// 人事模块 工资表单 删除
  140. /// </summary>
  141. /// <param name="dto"></param>
  142. /// <returns></returns>
  143. [HttpPost]
  144. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  145. public async Task<IActionResult> PostWageSheetDel(WageDelDto dto)
  146. {
  147. try
  148. {
  149. _result = await _wageSheetRep.Post_WageSheet_DelAsync(dto);
  150. if (_result.Code != 0)
  151. {
  152. return Ok(JsonView(false, _result.Msg));
  153. }
  154. }
  155. catch (Exception ex)
  156. {
  157. return Ok(JsonView(false, ex.Message));
  158. }
  159. return Ok(JsonView(true, _result.Msg, _result.Data));
  160. }
  161. /// <summary>
  162. /// 人事模块 工资表单 添加 Or 修改
  163. /// </summary>
  164. /// <param name="dto"></param>
  165. /// <returns></returns>
  166. [HttpPost]
  167. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  168. public async Task<IActionResult> PostWageSheetAddOrEdit(WageAddOrEditDto dto)
  169. {
  170. try
  171. {
  172. _result = await _wageSheetRep.Post_WageSheet_AddOrEditAsync(dto);
  173. if (_result.Code != 0)
  174. {
  175. return Ok(JsonView(false, _result.Msg));
  176. }
  177. }
  178. catch (Exception ex)
  179. {
  180. return Ok(JsonView(false, ex.Message));
  181. }
  182. return Ok(JsonView(true, _result.Msg, _result.Data));
  183. }
  184. /// <summary>
  185. /// 计算工资
  186. /// </summary>
  187. /// <returns></returns>
  188. [HttpPost]
  189. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  190. public async Task<IActionResult> SalaryCalculatorAsync(SalaryCalculatorDto dto)
  191. {
  192. Result result = new Result();
  193. Stopwatch sw = new Stopwatch();
  194. sw.Start();
  195. //参数处理
  196. string ymFormat = "yyyy-MM";
  197. DateTime yearMonthDt;
  198. bool yearMonthDttIsValid = DateTime.TryParseExact(dto.yearMonth, ymFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out yearMonthDt);
  199. if (!yearMonthDttIsValid)
  200. {
  201. return Ok(JsonView(false, "年月格式错误!正确时间格式:yyyy-MM "));
  202. }
  203. string thisYearMonth = dto.yearMonth;
  204. string preYearMonth = yearMonthDt.AddMonths(-1).ToString("yyyy-MM");
  205. //计算本月工资起止时间
  206. DateTime thisStartDt = Convert.ToDateTime(preYearMonth + "-28");
  207. DateTime thisEndDt = Convert.ToDateTime(thisYearMonth + "-27");
  208. //本月工资是否有数据 有数据则不计算
  209. result = await _wageSheetRep.Get_WageSheet_ListByYearMonthAsync(thisYearMonth);
  210. if (result.Code == 0 )
  211. {
  212. return Ok(JsonView(false, thisYearMonth + " 工资数据已存在,若无人员工资请手动添加!"));
  213. }
  214. //获取上个月工资信息
  215. List<Pm_WageSheet> preWageSheetItems = await _wageSheetRep._sqlSugar.Queryable<Pm_WageSheet>().Where(it => it.IsDel == 0 && it.YearMonth == preYearMonth).ToListAsync();
  216. if (preWageSheetItems.Count <= 0)
  217. {
  218. return Ok(JsonView(false, preYearMonth + " 工资数据不存在,请手动添加!"));
  219. }
  220. //获取OA系统内所有用户
  221. var nameData = await _usersRep.GetUserNameList(1);
  222. List<UserNameView>? userNames = nameData.Data;
  223. List<Pm_WageSheet> wageSheets = new List<Pm_WageSheet>();
  224. _result = await PayrollComputation.SalaryCalculatorAsync(preWageSheetItems, userNames,dto.UserId, thisYearMonth, thisStartDt, thisEndDt);
  225. #region 批量添加
  226. if (_result.Code != 0)
  227. {
  228. return Ok(JsonView(false, _result.Msg));
  229. }
  230. wageSheets = _result.Data;
  231. var add = await _wageSheetRep._sqlSugar.Insertable(wageSheets).ExecuteCommandAsync();
  232. if (add <= 0)
  233. {
  234. return Ok(JsonView(false, "操作失败!"));
  235. }
  236. #endregion
  237. #region 处理返回数据
  238. List <WageSheetItemInfoView> wageSheetItems = new List<WageSheetItemInfoView>();
  239. wageSheetItems = _mapper.Map<List<WageSheetItemInfoView>>(wageSheets);
  240. wageSheetItems = wageSheetItems.Select(it =>
  241. {
  242. UserNameView? uName1 = new UserNameView();
  243. UserNameView? uName2 = new UserNameView();
  244. uName1 = userNames.Where(it1 => it.UserId == it1.Id).FirstOrDefault();
  245. if (uName1 != null) it.Name = uName1.CnName;
  246. uName2 = userNames.Where(it1 => it.LastUpdateUserId == it1.Id).FirstOrDefault();
  247. if (uName2 != null) it.LastUpdateUserName = uName2.CnName;
  248. return it; }
  249. ).ToList();
  250. #endregion
  251. sw.Stop();
  252. return Ok(JsonView(true, "操作成功! 耗时:" + sw.ElapsedMilliseconds + "ms", wageSheetItems));
  253. }
  254. /// <summary>
  255. /// 计算工资 By YearMonth And UserId
  256. /// </summary>
  257. /// <returns></returns>
  258. [HttpPost]
  259. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  260. public async Task<IActionResult> SalaryCalculatorSingleAsync(SalaryCalculatorSingleDto dto)
  261. {
  262. Result result = new Result();
  263. Stopwatch sw = new Stopwatch();
  264. sw.Start();
  265. //参数处理
  266. string ymFormat = "yyyy-MM";
  267. string ymdFormat = "yyyy-MM-dd";
  268. DateTime yearMonthDt,startDt,endDt;
  269. bool yearMonthDtIsValid = DateTime.TryParseExact(dto.YearMonth, ymFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out yearMonthDt);
  270. bool startDtIsValid = DateTime.TryParseExact(dto.StartDate, ymdFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out startDt);
  271. bool endDtIsValid = DateTime.TryParseExact(dto.EndDate, ymdFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out endDt);
  272. if (!yearMonthDtIsValid)
  273. return Ok(JsonView(false, "年月格式错误!正确时间格式:yyyy-MM "));
  274. if (!startDtIsValid)
  275. return Ok(JsonView(false, "开始时间格式错误!正确时间格式:yyyy-MM-dd "));
  276. if (!yearMonthDtIsValid)
  277. return Ok(JsonView(false, "结束时间格式错误!正确时间格式:yyyy-MM-dd "));
  278. //本月工资是否有数据 有数据则不计算
  279. //result = await _wageSheetRep.Get_WageSheet_ListByYearMonthAsync(dto.YearMonth);
  280. //if (result.Code == 0)
  281. //{
  282. // return Ok(JsonView(false, dto.YearMonth + " 工资数据已存在,若无人员工资请手动添加!"));
  283. //}
  284. List<Pm_WageSheet> wageSheets = new List<Pm_WageSheet>();
  285. Pm_WageSheet wageSheet = _mapper.Map<Pm_WageSheet>(dto);
  286. wageSheets.Add(wageSheet);
  287. //获取OA系统内所有用户
  288. var nameData = await _usersRep.GetUserNameList(1);
  289. List<UserNameView>? userNames = nameData.Data;
  290. _result = await PayrollComputation.SalaryCalculatorAsync(wageSheets, userNames, dto.UserId, dto.YearMonth, startDt, endDt);
  291. if (_result.Code != 0)
  292. {
  293. return Ok(JsonView(false, _result.Msg));
  294. }
  295. List<Pm_WageSheet> wageSheets1 = new List<Pm_WageSheet>();
  296. wageSheets1 = _result.Data;
  297. #region 处理返回数据
  298. List<WageSheetInfoView> wageSheetItems = new List<WageSheetInfoView>();
  299. wageSheetItems = _mapper.Map<List<WageSheetInfoView>>(wageSheets1);
  300. wageSheetItems = wageSheetItems.Select(it =>
  301. {
  302. UserNameView? uName1 = new UserNameView();
  303. UserNameView? uName2 = new UserNameView();
  304. uName1 = userNames.Where(it1 => it.UserId == it1.Id).FirstOrDefault();
  305. if (uName1 != null) it.Name = uName1.CnName;
  306. uName2 = userNames.Where(it1 => it.LastUpdateUserId == it1.Id).FirstOrDefault();
  307. if (uName2 != null) it.LastUpdateUserName = uName2.CnName;
  308. return it;
  309. }
  310. ).ToList();
  311. #endregion
  312. sw.Stop();
  313. return Ok(JsonView(true, "操作成功!耗时:"+ sw.ElapsedMilliseconds +"ms", wageSheetItems[0]));
  314. }
  315. #endregion
  316. }
  317. }