PersonnelModuleController.cs 38 KB

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