PersonnelModuleController.cs 36 KB

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