PersonnelModuleController.cs 36 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837
  1. using Aspose.Cells;
  2. using OASystem.API.OAMethodLib;
  3. using OASystem.API.OAMethodLib.QiYeWeChatAPI;
  4. using OASystem.Domain.Dtos.PersonnelModule;
  5. using OASystem.Domain.Entities.PersonnelModule;
  6. using OASystem.Domain.ViewModels.PersonnelModule;
  7. using OASystem.Domain.ViewModels.QiYeWeChat;
  8. using OASystem.Infrastructure.Repositories.PersonnelModule;
  9. using System.Collections.Generic;
  10. using System.Data;
  11. using System.Diagnostics;
  12. using System.Globalization;
  13. using System.IO;
  14. namespace OASystem.API.Controllers
  15. {
  16. /// <summary>
  17. /// 人事模块
  18. /// </summary>
  19. [Route("api/[controller]/[action]")]
  20. public class PersonnelModuleController : ControllerBase
  21. {
  22. private Result _result;
  23. private readonly IMapper _mapper;
  24. private readonly decimal _chengDuMinimumWage = 2100.00M;
  25. private readonly IQiYeWeChatApiService _qiYeWeChatApiService;
  26. private readonly WageSheetRepository _wageSheetRep;
  27. private readonly UsersRepository _usersRep;
  28. /// <summary>
  29. /// 初始化
  30. /// </summary>
  31. /// <param name="qiYeWeChatApiService"></param>
  32. /// <param name="wageSheetRep"></param>
  33. /// <param name="usersRep"></param>
  34. /// <param name="mapper"></param>
  35. public PersonnelModuleController(IQiYeWeChatApiService qiYeWeChatApiService,WageSheetRepository wageSheetRep, UsersRepository usersRep, IMapper mapper)
  36. {
  37. _mapper = mapper;
  38. _usersRep = usersRep;
  39. _qiYeWeChatApiService = qiYeWeChatApiService;
  40. _wageSheetRep = wageSheetRep;
  41. _result = new Result();
  42. }
  43. #region 工资表单
  44. /// <summary>
  45. /// 工资 月列表
  46. /// </summary>
  47. /// <returns></returns>
  48. [HttpPost]
  49. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  50. public async Task<IActionResult> GetWageSheetMonth()
  51. {
  52. string sql = string.Format("Select * From Pm_WageIssueWorkingDay Where IsDel = 0 Order By YearMonth Desc");
  53. var data = await _wageSheetRep._sqlSugar.SqlQueryable<WageSheetMonthView>(sql).ToListAsync();
  54. return Ok(JsonView(true, "查询成功!", data));
  55. }
  56. /// <summary>
  57. /// 工资 工作日信息
  58. /// </summary>
  59. /// <returns></returns>
  60. [HttpPost]
  61. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  62. public async Task<IActionResult> GetWageSheetMonthWorkdays(string startDt, string endDt )
  63. {
  64. //参数处理
  65. string dtFormat = "yyyy-MM-dd";
  66. DateTime startDt1, endDt1;
  67. bool startDtIsValid = DateTime.TryParseExact(startDt, dtFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out startDt1);
  68. bool endDtIsValid = DateTime.TryParseExact(endDt, dtFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out endDt1);
  69. if (!startDtIsValid) return Ok(JsonView(false, "开始日期格式错误!正确时间格式:yyyy-MM-dd "));
  70. if (!endDtIsValid) return Ok(JsonView(false, "结束格式错误!正确时间格式:yyyy-MM-dd "));
  71. string sql = string.Format(@"Select * From Sys_Calendar
  72. Where Isdel = 0 And Dt between '{0}' And '{1}'", startDt, endDt);
  73. var data = await _wageSheetRep._sqlSugar.SqlQueryable<CalendarInfoView>(sql).ToListAsync();
  74. return Ok(JsonView(true, "查询成功!", data));
  75. }
  76. /// <summary>
  77. /// 工资 工作日信息
  78. /// </summary>
  79. /// <returns></returns>
  80. [HttpPost]
  81. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  82. public async Task<IActionResult> GetWageSheetMonthWorkdaysAddOrEdit(WageSheetMonthWorkdaysAddOrEditDto dto)
  83. {
  84. //参数处理
  85. string yearFormat = "yyyy-MM";
  86. string dtFormat = "yyyy-MM-dd";
  87. DateTime yearDt, startDt1, endDt1;
  88. bool yearDtIsValid = DateTime.TryParseExact(dto.YearMonth, yearFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out yearDt);
  89. bool startDtIsValid = DateTime.TryParseExact(dto.StartDate, dtFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out startDt1);
  90. bool endDtIsValid = DateTime.TryParseExact(dto.EndDate, dtFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out endDt1);
  91. if (!yearDtIsValid) return Ok(JsonView(false, "年月日期格式错误!正确时间格式:yyyy-MM "));
  92. if (!startDtIsValid) return Ok(JsonView(false, "开始日期格式错误!正确时间格式:yyyy-MM-dd "));
  93. if (!endDtIsValid) return Ok(JsonView(false, "结束格式错误!正确时间格式:yyyy-MM-dd "));
  94. #region 处理数据
  95. Pm_WageIssueWorkingDay pm_WageIssueWorkingDay1 = new Pm_WageIssueWorkingDay();
  96. pm_WageIssueWorkingDay1 = _mapper.Map<Pm_WageIssueWorkingDay>(dto);
  97. List<Sys_Calendar> sys_Calendars = new List<Sys_Calendar>();
  98. sys_Calendars = _mapper.Map<List<Sys_Calendar>>(dto.CalendarInfos);
  99. pm_WageIssueWorkingDay1.Workdays = sys_Calendars.Where(it => it.IsWorkDay == true).ToList().Count();
  100. foreach (var item in sys_Calendars)
  101. {
  102. item.Remark = pm_WageIssueWorkingDay1.Remark;
  103. item.CreateUserId = pm_WageIssueWorkingDay1.CreateUserId;
  104. item.CreateTime = pm_WageIssueWorkingDay1.CreateTime;
  105. }
  106. #endregion
  107. var _sqlSugar = _wageSheetRep._sqlSugar;
  108. _sqlSugar.BeginTran();
  109. try
  110. {
  111. //月份表是否存在
  112. Pm_WageIssueWorkingDay pm_WageIssueWorkingDay = new Pm_WageIssueWorkingDay()
  113. {
  114. YearMonth = dto.YearMonth,
  115. StartDate = dto.StartDate,
  116. EndDate = dto.EndDate,
  117. Workdays = dto.CalendarInfos.Where(it => it.IsWorkDay == true).ToList().Count()
  118. };
  119. string sql = string.Format("Select * From Pm_WageIssueWorkingDay Where Isdel = 0 And YearMonth='{0}'", dto.YearMonth);
  120. var workdsys = await _sqlSugar.SqlQueryable<Pm_WageIssueWorkingDay>(sql).FirstAsync();
  121. if (workdsys == null) //添加
  122. {
  123. pm_WageIssueWorkingDay.CreateUserId = dto.UserId;
  124. pm_WageIssueWorkingDay.IsDel = 0;
  125. int addId = await _sqlSugar.Insertable(pm_WageIssueWorkingDay).ExecuteReturnIdentityAsync();
  126. }
  127. else //更新
  128. {
  129. int updCount = await _sqlSugar.Updateable(pm_WageIssueWorkingDay)
  130. .IgnoreColumns(z => new { z.CreateUserId, z.CreateTime, z.DeleteUserId, z.DeleteTime, z.IsDel })
  131. .WhereColumns(it => it.Id)
  132. .ExecuteCommandAsync();
  133. }
  134. List<Sys_Calendar> sys_Calendars_add = new List<Sys_Calendar>();
  135. List<Sys_Calendar> sys_Calendars_update = new List<Sys_Calendar>();
  136. sys_Calendars_add = sys_Calendars.Where(it => it.Id == 0).ToList();
  137. sys_Calendars_update = sys_Calendars.Where(it => it.Id != 0).ToList();
  138. int add1 = 0;
  139. int upd = 0;
  140. if (sys_Calendars_add.Count > 0)
  141. {
  142. await _sqlSugar.Insertable(sys_Calendars_add).ExecuteReturnIdentityAsync();
  143. }
  144. if (sys_Calendars_update.Count > 0)
  145. {
  146. await _sqlSugar.Updateable<Sys_Calendar>(sys_Calendars)
  147. .UpdateColumns(it => new { it.Dt, it.IsWorkDay, it.IsHoliDay, it.HoliName })
  148. .WhereColumns(it => it.Id)
  149. .ExecuteCommandAsync();
  150. }
  151. _sqlSugar.CommitTran();
  152. return Ok(JsonView(true, "操作成功!"));
  153. }
  154. catch (Exception ex)
  155. {
  156. _sqlSugar.RollbackTran();
  157. return Ok(JsonView(false, ex.Message));
  158. }
  159. }
  160. /// <summary>
  161. /// 工资表单 基础数据源
  162. /// </summary>
  163. /// <returns></returns>
  164. [HttpPost]
  165. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  166. public async Task<IActionResult> GetWageSheetBasicsDataSource()
  167. {
  168. string companySql = string.Format("Select * From Sys_Company Where IsDel = 0");
  169. var compnayData = await _wageSheetRep._sqlSugar.SqlQueryable<CompanyNameView>(companySql).ToListAsync();
  170. string depSql = string.Format("Select * From Sys_Department Where IsDel = 0");
  171. var depData = await _wageSheetRep._sqlSugar.SqlQueryable<Domain.ViewModels.System.DepartmentView>(depSql).ToListAsync();
  172. //获取OA系统内所有用户
  173. var nameData = await _usersRep.GetUserNameList(1);
  174. if (nameData.Code != 0)
  175. {
  176. return Ok(JsonView(false, nameData.Msg));
  177. }
  178. var data = new {
  179. compnayData = compnayData,
  180. depData = depData,
  181. userNames = nameData.Data
  182. };
  183. return Ok(JsonView(true, "查询成功!", data));
  184. }
  185. /// <summary>
  186. /// 获取工资发放月份
  187. /// </summary>
  188. /// <param name="dto"></param>
  189. /// <returns></returns>
  190. [HttpPost]
  191. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  192. public async Task<IActionResult> GetWageYaerMonths(WageYearDto dto)
  193. {
  194. string sql = string.Format(@"Select * From Pm_WageIssueWorkingDay
  195. Where Isdel = 0 And YearMonth Like '%{0}%'
  196. Order By YearMonth Asc", dto.Year);
  197. var data = await _wageSheetRep._sqlSugar.SqlQueryable<WageYearMonthView>(sql).ToListAsync();
  198. return Ok(JsonView(true,"操作成功!", data));
  199. }
  200. /// <summary>
  201. /// 获取工资表单
  202. /// </summary>
  203. /// <param name="dto"></param>
  204. /// <returns></returns>
  205. [HttpPost]
  206. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  207. public async Task<IActionResult> GetWageSheetList(WageSheetListDto dto)
  208. {
  209. //参数处理
  210. string ymFormat = "yyyy-MM";
  211. DateTime yearMonthDt;
  212. bool yearMonthDttIsValid = DateTime.TryParseExact(dto.YearMonth, ymFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out yearMonthDt);
  213. if (!yearMonthDttIsValid)
  214. {
  215. _result.Msg = "年月格式错误!正确时间格式:yyyy-MM ";
  216. return Ok(JsonView(false, _result.Msg));
  217. }
  218. //获取月工资数据
  219. string yearMonth = yearMonthDt.ToString("yyyy-MM");
  220. if (dto.PortType == 1)
  221. {
  222. _result = await _wageSheetRep.Get_WageSheet_ListByYearMonthAsync(yearMonth);
  223. if (_result.Code != 0)
  224. {
  225. return Ok(JsonView(false, _result.Msg));
  226. }
  227. }
  228. else if (dto.PortType == 2)
  229. { }
  230. else if (dto.PortType == 3)
  231. { }
  232. else
  233. {
  234. return Ok(JsonView(false, "请选择正确的端口参数"));
  235. }
  236. return Ok(JsonView(true, _result.Msg, _result.Data));
  237. }
  238. /// <summary>
  239. /// 获取工资 详情
  240. /// </summary>
  241. /// <param name="dto"></param>
  242. /// <returns></returns>
  243. [HttpPost]
  244. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  245. public async Task<IActionResult> GetWageSheetById(WageSheetInfoDto dto)
  246. {
  247. if (dto.PortType == 1)
  248. {
  249. _result = await _wageSheetRep.Get_WageSheet_InfoByIdAsync(dto.Id);
  250. if (_result.Code != 0)
  251. {
  252. return Ok(JsonView(false, _result.Msg));
  253. }
  254. }
  255. else if (dto.PortType == 2)
  256. { }
  257. else if (dto.PortType == 3)
  258. { }
  259. else
  260. {
  261. return Ok(JsonView(false, "请选择正确的端口参数"));
  262. }
  263. return Ok(JsonView(true, _result.Msg, _result.Data));
  264. }
  265. /// <summary>
  266. /// 人事模块 工资表单 删除
  267. /// </summary>
  268. /// <param name="dto"></param>
  269. /// <returns></returns>
  270. [HttpPost]
  271. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  272. public async Task<IActionResult> PostWageSheetDel(WageDelDto dto)
  273. {
  274. try
  275. {
  276. _result = await _wageSheetRep.Post_WageSheet_DelAsync(dto);
  277. if (_result.Code != 0)
  278. {
  279. return Ok(JsonView(false, _result.Msg));
  280. }
  281. }
  282. catch (Exception ex)
  283. {
  284. return Ok(JsonView(false, ex.Message));
  285. }
  286. return Ok(JsonView(true, _result.Msg, _result.Data));
  287. }
  288. /// <summary>
  289. /// 人事模块 工资表单 添加 Or 修改
  290. /// </summary>
  291. /// <param name="dto"></param>
  292. /// <returns></returns>
  293. [HttpPost]
  294. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  295. public async Task<IActionResult> PostWageSheetAddOrEdit(WageAddOrEditDto dto)
  296. {
  297. try
  298. {
  299. Pm_WageSheet pm_WageSheet = new Pm_WageSheet();
  300. pm_WageSheet = _mapper.Map<Pm_WageSheet>(dto);
  301. pm_WageSheet.LastUpdateUserId = dto.CreateUserId;
  302. #region 计算工资
  303. //月工资
  304. decimal salary = pm_WageSheet.Basic + pm_WageSheet.Floats + pm_WageSheet.PostAllowance + pm_WageSheet.InformationSecurityFee + pm_WageSheet.OtherSubsidies;
  305. //扣款合计
  306. decimal totalDeduction = pm_WageSheet.SickLeave + pm_WageSheet.SomethingFalse + pm_WageSheet.LateTo + pm_WageSheet.LeaveEarly + pm_WageSheet.Absenteeism + pm_WageSheet.NotPunch +
  307. pm_WageSheet.ReservedFunds + pm_WageSheet.WithholdingInsurance + pm_WageSheet.OtherDeductions + pm_WageSheet.OtherDeductions;
  308. //实发合计 不含个税
  309. if (pm_WageSheet.RegularDays >= pm_WageSheet.WorkDays )
  310. {
  311. pm_WageSheet.RegularDays = pm_WageSheet.WorkDays;
  312. salary = salary + pm_WageSheet.Mealsupplement;
  313. }
  314. else
  315. {
  316. if (dto.UserId == 21) //21==张海麟
  317. {
  318. salary = salary + pm_WageSheet.Mealsupplement;
  319. }
  320. else
  321. {
  322. salary = salary = (PayrollComputation.ConvertToDecimal(salary / pm_WageSheet.WorkDays) * pm_WageSheet.RegularDays) + pm_WageSheet.Mealsupplement;
  323. }
  324. }
  325. decimal actualTotal = salary - totalDeduction;
  326. pm_WageSheet.Should = salary;
  327. pm_WageSheet.TotalDeductions = totalDeduction;
  328. pm_WageSheet.TotalRealHair = actualTotal - pm_WageSheet.WithholdingTax;
  329. pm_WageSheet.AfterTax = actualTotal - pm_WageSheet.WithholdingTax;
  330. #endregion
  331. _result = await _wageSheetRep.Post_WageSheet_AddOrEditAsync(dto, pm_WageSheet);
  332. if (_result.Code != 0)
  333. {
  334. return Ok(JsonView(false, _result.Msg));
  335. }
  336. }
  337. catch (Exception ex)
  338. {
  339. return Ok(JsonView(false, ex.Message));
  340. }
  341. return Ok(JsonView(true, _result.Msg, _result.Data));
  342. }
  343. /// <summary>
  344. /// 计算工资
  345. /// </summary>
  346. /// <returns></returns>
  347. [HttpPost]
  348. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  349. public async Task<IActionResult> SalaryCalculatorAsync(SalaryCalculatorDto dto)
  350. {
  351. Result result = new Result();
  352. Stopwatch sw = new Stopwatch();
  353. sw.Start();
  354. //参数处理
  355. string ymFormat = "yyyy-MM";
  356. string dtFormat = "yyyy-MM-dd";
  357. DateTime yearMonthDt,startDt,endDt;
  358. bool yearMonthDtIsValid = DateTime.TryParseExact(dto.yearMonth, ymFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out yearMonthDt);
  359. bool startDtIsValid = DateTime.TryParseExact(dto.startDt, dtFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out startDt);
  360. bool endDtIsValid = DateTime.TryParseExact(dto.endDt, dtFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out endDt);
  361. if (!yearMonthDtIsValid) return Ok(JsonView(false, "年月格式错误!正确时间格式:yyyy-MM "));
  362. if (!startDtIsValid) return Ok(JsonView(false, "开始日期格式错误!正确时间格式:yyyy-MM-dd "));
  363. if (!endDtIsValid) return Ok(JsonView(false, "结束格式错误!正确时间格式:yyyy-MM-dd "));
  364. string thisYearMonth = dto.yearMonth;
  365. string preYearMonth = yearMonthDt.AddMonths(-1).ToString("yyyy-MM");
  366. //计算本月工资起止时间 比如是2月的1号-28号,那就是2月1号的零点到3月1号的零点
  367. DateTime thisStartDt = startDt;
  368. DateTime thisEndDt = endDt; //
  369. //本月工资是否有数据 有数据则不计算
  370. result = await _wageSheetRep.Get_WageSheet_ListByYearMonthAsync(thisYearMonth);
  371. if (result.Code == 0 )
  372. {
  373. return Ok(JsonView(false, thisYearMonth + " 工资数据已存在,若无人员工资请手动添加!"));
  374. }
  375. //获取上个月工资信息
  376. List<Pm_WageSheet> preWageSheetItems = await _wageSheetRep._sqlSugar.Queryable<Pm_WageSheet>().Where(it => it.IsDel == 0 && it.YearMonth == preYearMonth).ToListAsync();
  377. preWageSheetItems = preWageSheetItems.OrderBy(it => it.UserId).ToList();
  378. if (preWageSheetItems.Count <= 0)
  379. {
  380. return Ok(JsonView(false, thisYearMonth + " 上月工资数据不存在,请手动添加!"));
  381. }
  382. //处理上个月同月同人 多条数据
  383. List<Pm_WageSheet> preWageSheetItems1 = new List<Pm_WageSheet>();
  384. preWageSheetItems1 = preWageSheetItems.GroupBy(it => new { it.YearMonth,it.UserId })
  385. .Select(it => it.FirstOrDefault(item => item.Basic !=0))
  386. .ToList();
  387. //获取OA系统内所有用户
  388. var nameData = await _usersRep.GetUserNameList(1);
  389. List<UserNameView>? userNames = nameData.Data;
  390. List<Pm_WageSheet> wageSheets = new List<Pm_WageSheet>();
  391. _result = await PayrollComputation.SalaryCalculatorAsync(preWageSheetItems1, userNames,dto.UserId, thisYearMonth, thisStartDt,thisEndDt);
  392. #region 批量添加
  393. if (_result.Code != 0)
  394. {
  395. return Ok(JsonView(false, _result.Msg));
  396. }
  397. wageSheets = _result.Data;
  398. var add = await _wageSheetRep._sqlSugar.Insertable(wageSheets).ExecuteCommandAsync();
  399. if (add <= 0)
  400. {
  401. return Ok(JsonView(false, "操作失败!"));
  402. }
  403. #endregion
  404. #region 处理返回数据
  405. //List <WageSheetItemInfoView> wageSheetItems = new List<WageSheetItemInfoView>();
  406. //wageSheetItems = _mapper.Map<List<WageSheetItemInfoView>>(wageSheets);
  407. //wageSheetItems = wageSheetItems.Select(it =>
  408. // {
  409. // UserNameView? uName1 = new UserNameView();
  410. // UserNameView? uName2 = new UserNameView();
  411. // uName1 = userNames.Where(it1 => it.UserId == it1.Id).FirstOrDefault();
  412. // if (uName1 != null) it.Name = uName1.CnName;
  413. // uName2 = userNames.Where(it1 => it.LastUpdateUserId == it1.Id).FirstOrDefault();
  414. // if (uName2 != null) it.LastUpdateUserName = uName2.CnName;
  415. // return it; }
  416. // ).ToList();
  417. #endregion
  418. sw.Stop();
  419. return Ok(JsonView(true, "操作成功! 耗时:" + (sw.ElapsedMilliseconds/1000) + "s"));
  420. }
  421. /// <summary>
  422. /// 计算工资 By YearMonth And UserId
  423. /// </summary>
  424. /// <returns></returns>
  425. [HttpPost]
  426. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  427. public async Task<IActionResult> SalaryCalculatorSingleAsync(SalaryCalculatorSingleDto dto)
  428. {
  429. Result result = new Result();
  430. Stopwatch sw = new Stopwatch();
  431. sw.Start();
  432. //参数处理
  433. string ymFormat = "yyyy-MM";
  434. string ymdFormat = "yyyy-MM-dd";
  435. DateTime yearMonthDt,startDt,endDt;
  436. bool yearMonthDtIsValid = DateTime.TryParseExact(dto.YearMonth, ymFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out yearMonthDt);
  437. bool startDtIsValid = DateTime.TryParseExact(dto.StartDate, ymdFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out startDt);
  438. bool endDtIsValid = DateTime.TryParseExact(dto.EndDate, ymdFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out endDt);
  439. if (!yearMonthDtIsValid) return Ok(JsonView(false, "年月格式错误!正确时间格式:yyyy-MM "));
  440. if (!startDtIsValid) return Ok(JsonView(false, "开始时间格式错误!正确时间格式:yyyy-MM-dd "));
  441. if (!yearMonthDtIsValid) return Ok(JsonView(false, "结束时间格式错误!正确时间格式:yyyy-MM-dd "));
  442. List<Pm_WageSheet> wageSheets = new List<Pm_WageSheet>();
  443. Pm_WageSheet wageSheet = _mapper.Map<Pm_WageSheet>(dto);
  444. wageSheets.Add(wageSheet);
  445. //获取OA系统内所有用户
  446. var nameData = await _usersRep.GetUserNameList(1);
  447. List<UserNameView>? userNames = nameData.Data;
  448. _result = await PayrollComputation.SalaryCalculatorAsync(wageSheets, userNames, dto.UserId, dto.YearMonth, startDt, endDt);
  449. if (_result.Code != 0)
  450. {
  451. return Ok(JsonView(false, _result.Msg));
  452. }
  453. List<Pm_WageSheet> wageSheets1 = new List<Pm_WageSheet>();
  454. wageSheets1 = _result.Data;
  455. #region 处理返回数据
  456. List<WageSheetInfoView> wageSheetItems = new List<WageSheetInfoView>();
  457. wageSheetItems = _mapper.Map<List<WageSheetInfoView>>(wageSheets1);
  458. wageSheetItems = wageSheetItems.Select(it =>
  459. {
  460. UserNameView? uName1 = new UserNameView();
  461. UserNameView? uName2 = new UserNameView();
  462. uName1 = userNames.Where(it1 => it.UserId == it1.Id).FirstOrDefault();
  463. if (uName1 != null) it.Name = uName1.CnName;
  464. uName2 = userNames.Where(it1 => it.LastUpdateUserId == it1.Id).FirstOrDefault();
  465. if (uName2 != null) it.LastUpdateUserName = uName2.CnName;
  466. return it;
  467. }
  468. ).ToList();
  469. #endregion
  470. sw.Stop();
  471. return Ok(JsonView(true, "操作成功!耗时:" + (sw.ElapsedMilliseconds / 1000) + "s", wageSheetItems[0]));
  472. }
  473. /// <summary>
  474. /// 导出工资单
  475. /// </summary>
  476. /// <returns></returns>
  477. [HttpPost]
  478. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  479. public async Task<IActionResult> ExportWageCard(string yearMonth)
  480. {
  481. Result result = new Result();
  482. Stopwatch sw = new Stopwatch();
  483. sw.Start();
  484. //参数处理
  485. string ymFormat = "yyyy-MM";
  486. DateTime yearMonthDt;
  487. bool yearMonthDtIsValid = DateTime.TryParseExact(yearMonth, ymFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out yearMonthDt);
  488. if (!yearMonthDtIsValid) return Ok(JsonView(false, "年月格式错误!正确时间格式:yyyy-MM "));
  489. //公司部门
  490. string sql = string.Format(@"Select row_number() over(order by pm_ws.Id) as Row_Number,
  491. sc.Id as CompanyId,sc.CompanyName,sd.Id as DepId,sd.DepName,
  492. sys_u1.CnName Name,sys_u2.CnName LastUpdateUserName,pm_ws.*
  493. From Pm_WageSheet pm_ws
  494. Left Join Sys_Users sys_u1 On pm_ws.UserId = sys_u1.Id
  495. Left Join Sys_Users sys_u2 On pm_ws.LastUpdateUserId = sys_u2.Id
  496. Left Join Sys_Company sc On sys_u1.companyId = sc.Id
  497. Left Join Sys_Department sd On sys_u1.DepId = sd.Id
  498. Where pm_ws.IsDel = 0 And pm_ws.YearMonth = '{0}'", yearMonth);
  499. var wageSheetList = await _wageSheetRep._sqlSugar.SqlQueryable<ExportWageSheetItemView>(sql).ToListAsync();
  500. if (wageSheetList.Count <= 0)
  501. {
  502. return Ok(JsonView(false, yearMonth + "暂无工资数据!"));
  503. }
  504. decimal SumPrice = 0.00M;
  505. foreach (var item in wageSheetList)
  506. {
  507. SumPrice += item.AfterTax;
  508. }
  509. WorkbookDesigner designer = new WorkbookDesigner();
  510. designer.Workbook = new Workbook(AppSettingsHelper.Get("ExcelBasePath") + "Template/工资详细清单.xlsx");
  511. designer.Workbook.Worksheets[0].Name = yearMonth +" 工资单";
  512. designer.SetDataSource("WageSheet", wageSheetList);
  513. designer.SetDataSource("YearMonth", yearMonth);
  514. designer.SetDataSource("StartEndDt", wageSheetList[0].StartDate +" - "+ wageSheetList[0].EndDate);
  515. designer.SetDataSource("WorkDays", wageSheetList[0].WorkDays);
  516. designer.SetDataSource("SumPrice", SumPrice);
  517. designer.SetDataSource("WageSheetTitle", "工资单");//
  518. designer.Process();
  519. string fileName = "WageCard/" + yearMonth + "_工资单_" + DateTime.Now.ToString("yyyyMMddHHmmss") + ".xlsx";
  520. string path = AppSettingsHelper.Get("ExcelBasePath");
  521. designer.Workbook.Save(path + fileName);
  522. designer = null;
  523. string excelPath = AppSettingsHelper.Get("ExcelFtpPath") + fileName;
  524. string url = AppSettingsHelper.Get("ExcelBaseUrl");
  525. string fileUrl = url + excelPath;
  526. sw.Stop();
  527. return Ok(JsonView(true, "操作成功!耗时:" + (sw.ElapsedMilliseconds / 1000) + "s", new { FileUrl = fileUrl }));
  528. }
  529. /// <summary>
  530. /// 下载个税模板
  531. /// </summary>
  532. /// <returns></returns>
  533. [HttpPost]
  534. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  535. public async Task<IActionResult> WageSheetTaxTemplate()
  536. {
  537. string serverUrl = AppSettingsHelper.Get("WageSheetExcelBaseUrl");
  538. return Ok(JsonView(true, "操作成功!",new { FileUrl = serverUrl + "Office/WageSheetFile/个税导入模板.xlsx" }));
  539. }
  540. /// <summary>
  541. /// 上传个税
  542. /// </summary>
  543. /// <returns></returns>
  544. [HttpPost]
  545. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  546. public async Task<IActionResult> UploadTax(IFormFile file)
  547. {
  548. try
  549. {
  550. var yearMonth = Request.Headers["YearMonth"].ToString();
  551. //string yearMonth = "2023-10";
  552. string ymFormat = "yyyy-MM";
  553. DateTime yearMonthDt;
  554. bool yearMonthDtIsValid = DateTime.TryParseExact(yearMonth, ymFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out yearMonthDt);
  555. if (!yearMonthDtIsValid) return Ok(JsonView(false, "年月格式错误!正确时间格式:yyyy-MM "));
  556. if (file != null)
  557. {
  558. var fileDir = AppSettingsHelper.Get("WageSheetExcelFptPath");
  559. //文件名称
  560. string projectFileName = file.FileName;
  561. //上传的文件的路径
  562. string filePath = "";
  563. if (!Directory.Exists(fileDir))
  564. {
  565. Directory.CreateDirectory(fileDir);
  566. }
  567. //上传的文件的路径
  568. filePath = fileDir + $@"\{projectFileName}";
  569. if (System.IO.File.Exists(filePath))
  570. {
  571. //删除文件
  572. System.IO.File.Delete(filePath);
  573. }
  574. using (FileStream fs = System.IO.File.Create(filePath))
  575. {
  576. file.CopyTo(fs);
  577. fs.Flush();
  578. }
  579. if (System.IO.File.Exists(filePath))
  580. {
  581. Workbook book = new Workbook(filePath);
  582. DataSet dataSet = new DataSet();
  583. if (book.Worksheets.Count > 0)
  584. {
  585. var sheet = book.Worksheets[0];
  586. if (sheet != null)
  587. {
  588. // sheets 中的数据必须存在
  589. if (sheet.Cells.MaxDataRow != -1 && sheet.Cells.MaxDataColumn != -1)
  590. {
  591. // 方法 ExportDataTable 的参数说明
  592. // 要导出的第一个单元格的行号。
  593. // 要导出的第一个单元格的列号。
  594. // 要导入的行数。
  595. // 要导入的列数。
  596. // 指示第一行的数据是否导出到DataTable的列名。
  597. DataTable dataTable = sheet.Cells.ExportDataTable(0, 0, sheet.Cells.MaxDataRow + 1, sheet.Cells.MaxDataColumn + 1, true);
  598. dataSet.Tables.Add(dataTable);
  599. DataTable taxData = dataSet.Tables[0];
  600. //公司部门
  601. string sql = string.Format(@"Select row_number() over(order by pm_ws.Id) as Row_Number,
  602. sc.Id as CompanyId,sc.CompanyName,sd.Id as DepId,sd.DepName,
  603. sys_u1.CnName Name,sys_u2.CnName LastUpdateUserName,pm_ws.*
  604. From Pm_WageSheet pm_ws
  605. Left Join Sys_Users sys_u1 On pm_ws.UserId = sys_u1.Id
  606. Left Join Sys_Users sys_u2 On pm_ws.LastUpdateUserId = sys_u2.Id
  607. Left Join Sys_Company sc On sys_u1.companyId = sc.Id
  608. Left Join Sys_Department sd On sys_u1.DepId = sd.Id
  609. Where pm_ws.IsDel = 0 And pm_ws.YearMonth = '{0}'
  610. Order By UserId Asc ", yearMonth);
  611. var wageSheetList = await _wageSheetRep._sqlSugar.SqlQueryable<WageSheetInfoView>(sql).ToListAsync();
  612. if (wageSheetList.Count <= 0)
  613. {
  614. return Ok(JsonView(false, yearMonth + "工资数据不存在,请先添加工资数据!"));
  615. }
  616. for (int i = 0; i < taxData.Rows.Count; i++)
  617. {
  618. string name = taxData.Rows[i][0].ToString().Trim();
  619. List<WageSheetInfoView> wageSheets = new List<WageSheetInfoView>();
  620. wageSheets = wageSheetList.Where(it => it.Name.Equals(name)).ToList();
  621. if (wageSheets.Count > 0)
  622. {
  623. wageSheetList.Where(it => it.Name.Equals(name))
  624. .Select(it =>
  625. {
  626. //修改 绩效不等于0.00M的数据
  627. decimal oldTax = it.WithholdingTax;
  628. decimal newTax = Convert.ToDecimal(taxData.Rows[i][1].ToString());
  629. it.WithholdingTax = newTax;
  630. it.TotalRealHair = it.Should - it.TotalDeductions - newTax;
  631. return it;
  632. })
  633. .ToList();
  634. }
  635. }
  636. List<Pm_WageSheet> wageSheets1 = new List<Pm_WageSheet>();
  637. wageSheets1 = _mapper.Map<List<Pm_WageSheet>>(wageSheetList);
  638. var updateStatus = _wageSheetRep._sqlSugar
  639. .Updateable(wageSheets1)
  640. .UpdateColumns(it => new { it.WithholdingTax,it.TotalRealHair})
  641. .ExecuteCommand();
  642. if (updateStatus<0)
  643. {
  644. return Ok(JsonView(false, "操作失败!"));
  645. }
  646. if (System.IO.File.Exists(filePath))
  647. {
  648. //删除文件
  649. System.IO.File.Delete(filePath);
  650. }
  651. return Ok(JsonView(true, "操作成功!"));
  652. }
  653. }
  654. else
  655. {
  656. return Ok(JsonView(false, "工作薄没有数据!"));
  657. }
  658. }
  659. }
  660. return Ok(JsonView(true, "上传成功!", projectFileName));
  661. }
  662. else
  663. {
  664. return Ok(JsonView(false, "上传失败!"));
  665. }
  666. }
  667. catch (Exception ex)
  668. {
  669. return Ok(JsonView(false, "程序错误!"));
  670. throw;
  671. }
  672. return Ok(JsonView(true, "操作成功!"));
  673. }
  674. /// <summary>
  675. /// 打卡记录测试
  676. /// </summary>
  677. /// <returns></returns>
  678. [HttpPost]
  679. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  680. public async Task<IActionResult> Test(string startDt,string endDt)
  681. {
  682. UserIdListView userIdListView = await _qiYeWeChatApiService.GetUserIdListAsync();
  683. if (userIdListView.errcode != 0)
  684. {
  685. _result.Msg = "【企业微信】【打卡】【获取员工ID】【Msg】" + userIdListView.errmsg;
  686. return Ok(JsonView(false, _result.Msg));
  687. }
  688. List<string> qyWhchatIdList = new List<string>();
  689. qyWhchatIdList = userIdListView.dept_user.Select(it => it.userid).ToList();
  690. var data = await _qiYeWeChatApiService.GetCheckinDataAsync(qyWhchatIdList,2,Convert.ToDateTime(startDt), Convert.ToDateTime(endDt));
  691. return Ok(JsonView(true, "操作成功!", data.checkindata));
  692. }
  693. #endregion
  694. }
  695. }