PersonnelModuleController.cs 58 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415
  1. using Aspose.Cells;
  2. using NPOI.POIFS.Crypt.Dsig;
  3. using OASystem.API.OAMethodLib;
  4. using OASystem.API.OAMethodLib.QiYeWeChatAPI;
  5. using OASystem.Domain.Dtos.PersonnelModule;
  6. using OASystem.Domain.Entities.PersonnelModule;
  7. using OASystem.Domain.ViewModels.PersonnelModule;
  8. using OASystem.Domain.ViewModels.QiYeWeChat;
  9. using OASystem.Infrastructure.Repositories.PersonnelModule;
  10. using StackExchange.Redis;
  11. using System.Collections.Generic;
  12. using System.Data;
  13. using System.Diagnostics;
  14. using System.Globalization;
  15. using System.IO;
  16. namespace OASystem.API.Controllers
  17. {
  18. /// <summary>
  19. /// 人事模块
  20. /// </summary>
  21. [Route("api/[controller]/[action]")]
  22. public class PersonnelModuleController : ControllerBase
  23. {
  24. private Result _result;
  25. private readonly IMapper _mapper;
  26. private readonly decimal _chengDuMinimumWage = 2100.00M;
  27. private readonly IQiYeWeChatApiService _qiYeWeChatApiService;
  28. private readonly WageSheetRepository _wageSheetRep;
  29. private readonly UsersRepository _usersRep;
  30. private readonly TaskAllocationRepository _taskAllocationRep;
  31. private string url;
  32. private string path;
  33. /// <summary>
  34. /// 初始化
  35. /// </summary>
  36. /// <param name="qiYeWeChatApiService"></param>
  37. /// <param name="wageSheetRep"></param>
  38. /// <param name="usersRep"></param>
  39. /// <param name="mapper"></param>
  40. public PersonnelModuleController(IQiYeWeChatApiService qiYeWeChatApiService,WageSheetRepository wageSheetRep, UsersRepository usersRep, IMapper mapper,
  41. TaskAllocationRepository taskAllocationRep)
  42. {
  43. _mapper = mapper;
  44. _usersRep = usersRep;
  45. _qiYeWeChatApiService = qiYeWeChatApiService;
  46. _wageSheetRep = wageSheetRep;
  47. _result = new Result();
  48. url = AppSettingsHelper.Get("ExcelBaseUrl");
  49. path = AppSettingsHelper.Get("ExcelBasePath");
  50. if (!System.IO.Directory.Exists(path))
  51. {
  52. System.IO.Directory.CreateDirectory(path);//不存在就创建文件夹
  53. }
  54. this._taskAllocationRep = taskAllocationRep;
  55. }
  56. #region 工资表单
  57. /// <summary>
  58. /// 工资 月列表
  59. /// </summary>
  60. /// <returns></returns>
  61. [HttpPost]
  62. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  63. public async Task<IActionResult> GetWageSheetMonth()
  64. {
  65. string sql = string.Format("Select * From Pm_WageIssueWorkingDay Where IsDel = 0 Order By YearMonth Desc");
  66. var data = await _wageSheetRep._sqlSugar.SqlQueryable<WageSheetMonthView>(sql).ToListAsync();
  67. return Ok(JsonView(true, "查询成功!", data));
  68. }
  69. /// <summary>
  70. /// 工资 工作日信息
  71. /// 查询
  72. /// </summary>
  73. /// <returns></returns>
  74. [HttpPost]
  75. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  76. public async Task<IActionResult> GetWageSheetMonthWorkdays(string startDt, string endDt )
  77. {
  78. //参数处理
  79. string dtFormat = "yyyy-MM-dd";
  80. DateTime startDt1, endDt1;
  81. bool startDtIsValid = DateTime.TryParseExact(startDt, dtFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out startDt1);
  82. bool endDtIsValid = DateTime.TryParseExact(endDt, dtFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out endDt1);
  83. if (!startDtIsValid) return Ok(JsonView(false, "开始日期格式错误!正确时间格式:yyyy-MM-dd "));
  84. if (!endDtIsValid) return Ok(JsonView(false, "结束格式错误!正确时间格式:yyyy-MM-dd "));
  85. string sql = string.Format(@"Select * From Sys_Calendar
  86. Where Isdel = 0 And Dt between '{0}' And '{1}'", startDt, endDt);
  87. var data = await _wageSheetRep._sqlSugar.SqlQueryable<CalendarInfoView>(sql).ToListAsync();
  88. return Ok(JsonView(true, "查询成功!", data));
  89. }
  90. /// <summary>
  91. /// 工资 工作日信息
  92. /// 编辑
  93. /// </summary>
  94. /// <returns></returns>
  95. [HttpPost]
  96. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  97. public async Task<IActionResult> GetWageSheetMonthWorkdaysAddOrEdit(WageSheetMonthWorkdaysAddOrEditDto dto)
  98. {
  99. //参数处理
  100. string yearFormat = "yyyy-MM";
  101. string dtFormat = "yyyy-MM-dd";
  102. DateTime yearDt, startDt1, endDt1;
  103. bool yearDtIsValid = DateTime.TryParseExact(dto.YearMonth, yearFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out yearDt);
  104. bool startDtIsValid = DateTime.TryParseExact(dto.StartDate, dtFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out startDt1);
  105. bool endDtIsValid = DateTime.TryParseExact(dto.EndDate, dtFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out endDt1);
  106. if (!yearDtIsValid) return Ok(JsonView(false, "年月日期格式错误!正确时间格式:yyyy-MM "));
  107. if (!startDtIsValid) return Ok(JsonView(false, "开始日期格式错误!正确时间格式:yyyy-MM-dd "));
  108. if (!endDtIsValid) return Ok(JsonView(false, "结束格式错误!正确时间格式:yyyy-MM-dd "));
  109. #region 处理数据
  110. Pm_WageIssueWorkingDay pm_WageIssueWorkingDay1 = new Pm_WageIssueWorkingDay();
  111. pm_WageIssueWorkingDay1 = _mapper.Map<Pm_WageIssueWorkingDay>(dto);
  112. List<Sys_Calendar> sys_Calendars = new List<Sys_Calendar>();
  113. sys_Calendars = _mapper.Map<List<Sys_Calendar>>(dto.CalendarInfos);
  114. if (sys_Calendars.Count > 0)
  115. {
  116. sys_Calendars = sys_Calendars.OrderBy(it => it.Dt).ToList();
  117. }
  118. pm_WageIssueWorkingDay1.Workdays = sys_Calendars.Where(it => it.IsWorkDay == true).ToList().Count();
  119. foreach (var item in sys_Calendars)
  120. {
  121. item.Remark = pm_WageIssueWorkingDay1.Remark;
  122. item.CreateUserId = pm_WageIssueWorkingDay1.CreateUserId;
  123. item.CreateTime = pm_WageIssueWorkingDay1.CreateTime;
  124. }
  125. #endregion
  126. var _sqlSugar = _wageSheetRep._sqlSugar;
  127. _sqlSugar.BeginTran();
  128. try
  129. {
  130. List<Sys_Calendar> sys_Calendars_add = new List<Sys_Calendar>();
  131. List<Sys_Calendar> sys_Calendars_update = new List<Sys_Calendar>();
  132. sys_Calendars_add = sys_Calendars.Where(it => it.Id == 0).OrderBy(it => it.Dt).ToList();
  133. sys_Calendars_update = sys_Calendars.Where(it => it.Id != 0).OrderBy(it => it.Dt).ToList();
  134. int add1 = 0;
  135. int upd = 0;
  136. if (sys_Calendars_add.Count > 0)
  137. {
  138. var calendarsAdd = await _sqlSugar.Insertable(sys_Calendars_add).ExecuteReturnIdentityAsync();
  139. if (calendarsAdd < 0)
  140. {
  141. _sqlSugar.RollbackTran();
  142. return Ok(JsonView(false, "工作日/节假日/休息日添加失败!"));
  143. }
  144. }
  145. if (sys_Calendars_update.Count > 0)
  146. {
  147. var calendarsUpdate = await _sqlSugar.Updateable<Sys_Calendar>(sys_Calendars)
  148. .UpdateColumns(it => new { it.Dt, it.IsWorkDay, it.IsHoliDay, it.HoliName })
  149. .WhereColumns(it => it.Id)
  150. .ExecuteCommandAsync();
  151. if (calendarsUpdate < 0)
  152. {
  153. _sqlSugar.RollbackTran();
  154. return Ok(JsonView(false, "工作日/节假日/休息日编辑失败!"));
  155. }
  156. }
  157. var calendarsDatas = await _sqlSugar.Queryable<Sys_Calendar>()
  158. .Where(it => Convert.ToDateTime(it.Dt) >= Convert.ToDateTime(dto.StartDate) && Convert.ToDateTime(it.Dt) <= Convert.ToDateTime(dto.EndDate)).ToListAsync();
  159. if (calendarsDatas.Count < 0)
  160. {
  161. _sqlSugar.RollbackTran();
  162. return Ok(JsonView(false, "日期包暂无工作日/节假日/休息日的信息!"));
  163. }
  164. //月份表是否存在
  165. Pm_WageIssueWorkingDay pm_WageIssueWorkingDay = new Pm_WageIssueWorkingDay()
  166. {
  167. YearMonth = dto.YearMonth,
  168. StartDate = dto.StartDate,
  169. EndDate = dto.EndDate,
  170. Workdays = calendarsDatas.Where(it => it.IsWorkDay == true).ToList().Count()
  171. };
  172. string sql = string.Format("Select * From Pm_WageIssueWorkingDay Where Isdel = 0 And YearMonth='{0}'", dto.YearMonth);
  173. var workdsys = await _sqlSugar.SqlQueryable<Pm_WageIssueWorkingDay>(sql).FirstAsync();
  174. pm_WageIssueWorkingDay.CreateUserId = dto.UserId;
  175. pm_WageIssueWorkingDay.IsDel = 0;
  176. if (workdsys == null) //添加
  177. {
  178. int addId = await _sqlSugar.Insertable(pm_WageIssueWorkingDay).ExecuteReturnIdentityAsync();
  179. if (addId < 0)
  180. {
  181. _sqlSugar.RollbackTran();
  182. return Ok(JsonView(false, "工作日设置添加失败!"));
  183. }
  184. }
  185. else //更新
  186. {
  187. int updCount = await _sqlSugar.Updateable(pm_WageIssueWorkingDay)
  188. .IgnoreColumns(z => new { z.CreateUserId, z.CreateTime, z.DeleteUserId, z.DeleteTime, z.IsDel })
  189. .WhereColumns(it => it.YearMonth)
  190. .ExecuteCommandAsync();
  191. if (updCount < 0)
  192. {
  193. _sqlSugar.RollbackTran();
  194. return Ok(JsonView(false, "工作日设置编辑失败!"));
  195. }
  196. }
  197. _sqlSugar.CommitTran();
  198. return Ok(JsonView(true, "操作成功!"));
  199. }
  200. catch (Exception ex)
  201. {
  202. _sqlSugar.RollbackTran();
  203. return Ok(JsonView(false, ex.Message));
  204. }
  205. }
  206. /// <summary>
  207. /// 工资表单 基础数据源
  208. /// </summary>
  209. /// <returns></returns>
  210. [HttpPost]
  211. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  212. public async Task<IActionResult> GetWageSheetBasicsDataSource()
  213. {
  214. string companySql = string.Format("Select * From Sys_Company Where IsDel = 0");
  215. var compnayData = await _wageSheetRep._sqlSugar.SqlQueryable<CompanyNameView>(companySql).ToListAsync();
  216. string depSql = string.Format("Select * From Sys_Department Where IsDel = 0");
  217. var depData = await _wageSheetRep._sqlSugar.SqlQueryable<Domain.ViewModels.System.DepartmentView>(depSql).ToListAsync();
  218. //获取OA系统内所有用户
  219. var nameData = await _usersRep.GetUserNameList(1);
  220. if (nameData.Code != 0)
  221. {
  222. return Ok(JsonView(false, nameData.Msg));
  223. }
  224. var data = new {
  225. compnayData = compnayData,
  226. depData = depData,
  227. userNames = nameData.Data
  228. };
  229. return Ok(JsonView(true, "查询成功!", data));
  230. }
  231. /// <summary>
  232. /// 获取工资发放月份
  233. /// </summary>
  234. /// <param name="dto"></param>
  235. /// <returns></returns>
  236. [HttpPost]
  237. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  238. public async Task<IActionResult> GetWageYaerMonths(WageYearDto dto)
  239. {
  240. string sql = string.Format(@"Select * From Pm_WageIssueWorkingDay
  241. Where Isdel = 0 And YearMonth Like '%{0}%'
  242. Order By YearMonth Asc", dto.Year);
  243. var data = await _wageSheetRep._sqlSugar.SqlQueryable<WageYearMonthView>(sql).ToListAsync();
  244. return Ok(JsonView(true,"操作成功!", data));
  245. }
  246. /// <summary>
  247. /// 获取工资表单
  248. /// </summary>
  249. /// <param name="dto"></param>
  250. /// <returns></returns>
  251. [HttpPost]
  252. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  253. public async Task<IActionResult> GetWageSheetList(WageSheetListDto dto)
  254. {
  255. //参数处理
  256. string ymFormat = "yyyy-MM";
  257. DateTime yearMonthDt;
  258. bool yearMonthDttIsValid = DateTime.TryParseExact(dto.YearMonth, ymFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out yearMonthDt);
  259. if (!yearMonthDttIsValid)
  260. {
  261. _result.Msg = "年月格式错误!正确时间格式:yyyy-MM ";
  262. return Ok(JsonView(false, _result.Msg));
  263. }
  264. //获取月工资数据
  265. string yearMonth = yearMonthDt.ToString("yyyy-MM");
  266. if (dto.PortType == 1)
  267. {
  268. _result = await _wageSheetRep.Get_WageSheet_ListByYearMonthAsync(yearMonth);
  269. if (_result.Code != 0)
  270. {
  271. return Ok(JsonView(false, _result.Msg));
  272. }
  273. }
  274. else if (dto.PortType == 2)
  275. { }
  276. else if (dto.PortType == 3)
  277. { }
  278. else
  279. {
  280. return Ok(JsonView(false, "请选择正确的端口参数"));
  281. }
  282. return Ok(JsonView(true, _result.Msg, _result.Data));
  283. }
  284. /// <summary>
  285. /// 获取工资 详情
  286. /// </summary>
  287. /// <param name="dto"></param>
  288. /// <returns></returns>
  289. [HttpPost]
  290. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  291. public async Task<IActionResult> GetWageSheetById(WageSheetInfoDto dto)
  292. {
  293. if (dto.PortType == 1)
  294. {
  295. _result = await _wageSheetRep.Get_WageSheet_InfoByIdAsync(dto.Id);
  296. if (_result.Code != 0)
  297. {
  298. return Ok(JsonView(false, _result.Msg));
  299. }
  300. }
  301. else if (dto.PortType == 2)
  302. { }
  303. else if (dto.PortType == 3)
  304. { }
  305. else
  306. {
  307. return Ok(JsonView(false, "请选择正确的端口参数"));
  308. }
  309. return Ok(JsonView(true, _result.Msg, _result.Data));
  310. }
  311. /// <summary>
  312. /// 人事模块 工资表单 删除
  313. /// </summary>
  314. /// <param name="dto"></param>
  315. /// <returns></returns>
  316. [HttpPost]
  317. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  318. public async Task<IActionResult> PostWageSheetDel(WageDelDto dto)
  319. {
  320. try
  321. {
  322. _result = await _wageSheetRep.Post_WageSheet_DelAsync(dto);
  323. if (_result.Code != 0)
  324. {
  325. return Ok(JsonView(false, _result.Msg));
  326. }
  327. }
  328. catch (Exception ex)
  329. {
  330. return Ok(JsonView(false, ex.Message));
  331. }
  332. return Ok(JsonView(true, _result.Msg, _result.Data));
  333. }
  334. /// <summary>
  335. /// 人事模块 工资表单 添加 Or 修改
  336. /// </summary>
  337. /// <param name="dto"></param>
  338. /// <returns></returns>
  339. [HttpPost]
  340. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  341. public async Task<IActionResult> PostWageSheetAddOrEdit(WageAddOrEditDto dto)
  342. {
  343. try
  344. {
  345. Pm_WageSheet pm_WageSheet = new Pm_WageSheet();
  346. pm_WageSheet = _mapper.Map<Pm_WageSheet>(dto);
  347. pm_WageSheet.LastUpdateUserId = dto.CreateUserId;
  348. #region 计算工资
  349. //月工资
  350. decimal salary = pm_WageSheet.Basic + pm_WageSheet.Floats + pm_WageSheet.PostAllowance + pm_WageSheet.InformationSecurityFee + pm_WageSheet.OtherSubsidies;
  351. //扣款合计
  352. decimal totalDeduction = pm_WageSheet.SickLeave + pm_WageSheet.SomethingFalse + pm_WageSheet.LateTo + pm_WageSheet.LeaveEarly + pm_WageSheet.Absenteeism + pm_WageSheet.NotPunch +
  353. pm_WageSheet.ReservedFunds + pm_WageSheet.WithholdingInsurance + pm_WageSheet.OtherDeductions + pm_WageSheet.OtherDeductions;
  354. //实发合计 不含个税
  355. if (pm_WageSheet.RegularDays >= pm_WageSheet.WorkDays )
  356. {
  357. pm_WageSheet.RegularDays = pm_WageSheet.WorkDays;
  358. salary = salary + pm_WageSheet.Mealsupplement + pm_WageSheet.OtherHandle;
  359. }
  360. else
  361. {
  362. if (dto.UserId == 21) //21==张海麟
  363. {
  364. salary = salary + pm_WageSheet.Mealsupplement + pm_WageSheet.OtherHandle;
  365. }
  366. else
  367. {
  368. salary = PayrollComputation.ConvertToDecimal(salary / pm_WageSheet.WorkDays * pm_WageSheet.RegularDays + pm_WageSheet.Mealsupplement + pm_WageSheet.OtherHandle);
  369. }
  370. }
  371. decimal actualTotal = salary - totalDeduction;
  372. pm_WageSheet.Should = salary;
  373. pm_WageSheet.TotalDeductions = totalDeduction;
  374. pm_WageSheet.TotalRealHair = actualTotal - pm_WageSheet.WithholdingTax;
  375. pm_WageSheet.AfterTax = actualTotal - pm_WageSheet.WithholdingTax;
  376. #endregion
  377. _result = await _wageSheetRep.Post_WageSheet_AddOrEditAsync(dto, pm_WageSheet);
  378. if (_result.Code != 0)
  379. {
  380. return Ok(JsonView(false, _result.Msg));
  381. }
  382. }
  383. catch (Exception ex)
  384. {
  385. return Ok(JsonView(false, ex.Message));
  386. }
  387. return Ok(JsonView(true, _result.Msg, _result.Data));
  388. }
  389. /// <summary>
  390. /// 计算工资
  391. /// </summary>
  392. /// <returns></returns>
  393. [HttpPost]
  394. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  395. public async Task<IActionResult> SalaryCalculatorAsync(SalaryCalculatorDto dto)
  396. {
  397. Result result = new Result();
  398. Stopwatch sw = new Stopwatch();
  399. sw.Start();
  400. //参数处理
  401. string ymFormat = "yyyy-MM";
  402. string dtFormat = "yyyy-MM-dd";
  403. DateTime yearMonthDt,startDt,endDt;
  404. bool yearMonthDtIsValid = DateTime.TryParseExact(dto.yearMonth, ymFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out yearMonthDt);
  405. bool startDtIsValid = DateTime.TryParseExact(dto.startDt, dtFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out startDt);
  406. bool endDtIsValid = DateTime.TryParseExact(dto.endDt, dtFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out endDt);
  407. if (!yearMonthDtIsValid) return Ok(JsonView(false, "年月格式错误!正确时间格式:yyyy-MM "));
  408. if (!startDtIsValid) return Ok(JsonView(false, "开始日期格式错误!正确时间格式:yyyy-MM-dd "));
  409. if (!endDtIsValid) return Ok(JsonView(false, "结束格式错误!正确时间格式:yyyy-MM-dd "));
  410. string thisYearMonth = dto.yearMonth;
  411. string preYearMonth = yearMonthDt.AddMonths(-1).ToString("yyyy-MM");
  412. //计算本月工资起止时间 比如是2月的1号-28号,那就是2月1号的零点到3月1号的零点
  413. DateTime thisStartDt = startDt;
  414. DateTime thisEndDt = endDt; //
  415. //本月工资是否有数据 有数据则不计算
  416. result = await _wageSheetRep.Get_WageSheet_ListByYearMonthAsync(thisYearMonth);
  417. if (result.Code == 0 )
  418. {
  419. return Ok(JsonView(false, thisYearMonth + " 工资数据已存在,若无人员工资请手动添加!"));
  420. }
  421. //获取上个月工资信息
  422. List<Pm_WageSheet> preWageSheetItems = await _wageSheetRep._sqlSugar.Queryable<Pm_WageSheet>().Where(it => it.IsDel == 0 && it.YearMonth == preYearMonth).ToListAsync();
  423. preWageSheetItems = preWageSheetItems.OrderBy(it => it.UserId).ToList();
  424. if (preWageSheetItems.Count <= 0)
  425. {
  426. return Ok(JsonView(false, thisYearMonth + " 上月工资数据不存在,请手动添加!"));
  427. }
  428. //处理上个月同月同人 多条数据
  429. List<Pm_WageSheet> preWageSheetItems1 = new List<Pm_WageSheet>();
  430. preWageSheetItems1 = preWageSheetItems.GroupBy(it => new { it.YearMonth,it.UserId })
  431. .Select(it => it.FirstOrDefault(item => item.Basic !=0))
  432. .ToList();
  433. //获取OA系统内所有用户
  434. var nameData = await _usersRep.GetUserNameList(1);
  435. List<UserNameView>? userNames = nameData.Data;
  436. List<Pm_WageSheet> wageSheets = new List<Pm_WageSheet>();
  437. _result = await PayrollComputation.SalaryCalculatorAsync(preWageSheetItems1, userNames,dto.UserId, thisYearMonth, thisStartDt,thisEndDt);
  438. #region 批量添加
  439. if (_result.Code != 0)
  440. {
  441. return Ok(JsonView(false, _result.Msg));
  442. }
  443. wageSheets = _result.Data;
  444. var add = await _wageSheetRep._sqlSugar.Insertable(wageSheets).ExecuteCommandAsync();
  445. if (add <= 0)
  446. {
  447. return Ok(JsonView(false, "操作失败!"));
  448. }
  449. #endregion
  450. #region 处理返回数据
  451. //List <WageSheetItemInfoView> wageSheetItems = new List<WageSheetItemInfoView>();
  452. //wageSheetItems = _mapper.Map<List<WageSheetItemInfoView>>(wageSheets);
  453. //wageSheetItems = wageSheetItems.Select(it =>
  454. // {
  455. // UserNameView? uName1 = new UserNameView();
  456. // UserNameView? uName2 = new UserNameView();
  457. // uName1 = userNames.Where(it1 => it.UserId == it1.Id).FirstOrDefault();
  458. // if (uName1 != null) it.Name = uName1.CnName;
  459. // uName2 = userNames.Where(it1 => it.LastUpdateUserId == it1.Id).FirstOrDefault();
  460. // if (uName2 != null) it.LastUpdateUserName = uName2.CnName;
  461. // return it; }
  462. // ).ToList();
  463. #endregion
  464. sw.Stop();
  465. return Ok(JsonView(true, "操作成功! 耗时:" + (sw.ElapsedMilliseconds/1000) + "s"));
  466. }
  467. /// <summary>
  468. /// 计算工资 By YearMonth And UserId
  469. /// </summary>
  470. /// <returns></returns>
  471. [HttpPost]
  472. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  473. public async Task<IActionResult> SalaryCalculatorSingleAsync(SalaryCalculatorSingleDto dto)
  474. {
  475. Result result = new Result();
  476. Stopwatch sw = new Stopwatch();
  477. sw.Start();
  478. //参数处理
  479. string ymFormat = "yyyy-MM";
  480. string ymdFormat = "yyyy-MM-dd";
  481. DateTime yearMonthDt,startDt,endDt;
  482. bool yearMonthDtIsValid = DateTime.TryParseExact(dto.YearMonth, ymFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out yearMonthDt);
  483. bool startDtIsValid = DateTime.TryParseExact(dto.StartDate, ymdFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out startDt);
  484. bool endDtIsValid = DateTime.TryParseExact(dto.EndDate, ymdFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out endDt);
  485. if (!yearMonthDtIsValid) return Ok(JsonView(false, "年月格式错误!正确时间格式:yyyy-MM "));
  486. if (!startDtIsValid) return Ok(JsonView(false, "开始时间格式错误!正确时间格式:yyyy-MM-dd "));
  487. if (!yearMonthDtIsValid) return Ok(JsonView(false, "结束时间格式错误!正确时间格式:yyyy-MM-dd "));
  488. List<Pm_WageSheet> wageSheets = new List<Pm_WageSheet>();
  489. Pm_WageSheet wageSheet = _mapper.Map<Pm_WageSheet>(dto);
  490. Pm_WageSheet wageSheet1 = await _wageSheetRep._sqlSugar.Queryable<Pm_WageSheet>().Where(it => it.UserId == dto.UserId && it.YearMonth == dto.YearMonth && it.StartDate == dto.StartDate && it.EndDate == dto.EndDate).FirstAsync();
  491. if (wageSheet1 != null )
  492. {
  493. wageSheet.Id = wageSheet1.Id;
  494. }
  495. wageSheets.Add(wageSheet);
  496. //获取OA系统内所有用户
  497. var nameData = await _usersRep.GetUserNameList(1);
  498. List<UserNameView>? userNames = nameData.Data;
  499. _result = await PayrollComputation.SalaryCalculatorAsync(wageSheets, userNames, dto.UserId, dto.YearMonth, startDt, endDt);
  500. if (_result.Code != 0)
  501. {
  502. return Ok(JsonView(false, _result.Msg));
  503. }
  504. List<Pm_WageSheet> wageSheets1 = new List<Pm_WageSheet>();
  505. wageSheets1 = _result.Data;
  506. #region 处理返回数据
  507. List<WageSheetInfoView> wageSheetItems = new List<WageSheetInfoView>();
  508. wageSheetItems = _mapper.Map<List<WageSheetInfoView>>(wageSheets1);
  509. wageSheetItems = wageSheetItems.Select(it =>
  510. {
  511. UserNameView? uName1 = new UserNameView();
  512. UserNameView? uName2 = new UserNameView();
  513. uName1 = userNames.Where(it1 => it.UserId == it1.Id).FirstOrDefault();
  514. if (uName1 != null) it.Name = uName1.CnName;
  515. uName2 = userNames.Where(it1 => it.LastUpdateUserId == it1.Id).FirstOrDefault();
  516. if (uName2 != null) it.LastUpdateUserName = uName2.CnName;
  517. return it;
  518. }
  519. ).ToList();
  520. #endregion
  521. sw.Stop();
  522. return Ok(JsonView(true, "操作成功!耗时:" + (sw.ElapsedMilliseconds / 1000) + "s", wageSheetItems[0]));
  523. }
  524. /// <summary>
  525. /// 导出工资单
  526. /// </summary>
  527. /// <returns></returns>
  528. [HttpPost]
  529. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  530. public async Task<IActionResult> ExportWageCard(string yearMonth)
  531. {
  532. Result result = new Result();
  533. Stopwatch sw = new Stopwatch();
  534. sw.Start();
  535. //参数处理
  536. string ymFormat = "yyyy-MM";
  537. DateTime yearMonthDt;
  538. bool yearMonthDtIsValid = DateTime.TryParseExact(yearMonth, ymFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out yearMonthDt);
  539. if (!yearMonthDtIsValid) return Ok(JsonView(false, "年月格式错误!正确时间格式:yyyy-MM "));
  540. //公司部门
  541. string sql = string.Format(@"Select row_number() over(order by pm_ws.Id) as Row_Number,
  542. sc.Id as CompanyId,sc.CompanyName,sd.Id as DepId,sd.DepName,
  543. sys_u1.CnName Name,sys_u2.CnName LastUpdateUserName,pm_ws.*
  544. From Pm_WageSheet pm_ws
  545. Left Join Sys_Users sys_u1 On pm_ws.UserId = sys_u1.Id
  546. Left Join Sys_Users sys_u2 On pm_ws.LastUpdateUserId = sys_u2.Id
  547. Left Join Sys_Company sc On sys_u1.companyId = sc.Id
  548. Left Join Sys_Department sd On sys_u1.DepId = sd.Id
  549. Where pm_ws.IsDel = 0 And pm_ws.YearMonth = '{0}'", yearMonth);
  550. var wageSheetList = await _wageSheetRep._sqlSugar.SqlQueryable<ExportWageSheetItemView>(sql).ToListAsync();
  551. if (wageSheetList.Count <= 0)
  552. {
  553. return Ok(JsonView(false, yearMonth + "暂无工资数据!"));
  554. }
  555. decimal SumPrice = 0.00M;
  556. foreach (var item in wageSheetList)
  557. {
  558. SumPrice += item.AfterTax;
  559. }
  560. WorkbookDesigner designer = new WorkbookDesigner();
  561. designer.Workbook = new Workbook(AppSettingsHelper.Get("ExcelBasePath") + "Template/工资详细清单.xlsx");
  562. designer.Workbook.Worksheets[0].Name = yearMonth +" 工资单";
  563. designer.SetDataSource("WageSheet", wageSheetList);
  564. designer.SetDataSource("YearMonth", yearMonth);
  565. designer.SetDataSource("StartEndDt", wageSheetList[0].StartDate +" - "+ wageSheetList[0].EndDate);
  566. designer.SetDataSource("WorkDays", wageSheetList[0].WorkDays);
  567. designer.SetDataSource("SumPrice", SumPrice);
  568. designer.SetDataSource("WageSheetTitle", "工资单");//
  569. designer.Process();
  570. string fileName = "WageCard/" + yearMonth + "_工资单_" + DateTime.Now.ToString("yyyyMMddHHmmss") + ".xlsx";
  571. string path = AppSettingsHelper.Get("ExcelBasePath");
  572. designer.Workbook.Save(path + fileName);
  573. designer = null;
  574. string excelPath = AppSettingsHelper.Get("ExcelFtpPath") + fileName;
  575. string url = AppSettingsHelper.Get("ExcelBaseUrl");
  576. string fileUrl = url + excelPath;
  577. sw.Stop();
  578. return Ok(JsonView(true, "操作成功!耗时:" + (sw.ElapsedMilliseconds / 1000) + "s", new { FileUrl = fileUrl }));
  579. }
  580. /// <summary>
  581. /// 下载个税模板
  582. /// </summary>
  583. /// <returns></returns>
  584. [HttpPost]
  585. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  586. public async Task<IActionResult> WageSheetTaxTemplate()
  587. {
  588. string serverUrl = AppSettingsHelper.Get("WageSheetExcelBaseUrl");
  589. var userData = await _usersRep.GetUserNameList(1);
  590. if (userData.Code == 0)
  591. {
  592. var userNames = userData.Data;
  593. List<string> names = new List<string>();
  594. List<UserNameView> users = new List<UserNameView>();
  595. names.Add("管理员");
  596. names.Add("国交共享号");
  597. names.Add("人事审核号");
  598. names.Add("国交主管号");
  599. List<TaxTemlateViuw> taxs = new List<TaxTemlateViuw>();
  600. users = JsonConvert.DeserializeObject<List<UserNameView>>(JsonConvert.SerializeObject(userNames));
  601. foreach (UserNameView item in users)
  602. {
  603. string uName = item.CnName;
  604. if (!names.Contains(uName))
  605. {
  606. taxs.Add(new TaxTemlateViuw { UserName = item.CnName });
  607. }
  608. }
  609. if (taxs.Count > 0)
  610. {
  611. WorkbookDesigner designer = new WorkbookDesigner();
  612. designer.Workbook = new Workbook(AppSettingsHelper.Get("ExcelBasePath") + "Template/个税导入模板.xlsx");
  613. designer.Workbook.Worksheets[0].Name = "个税模板";
  614. designer.SetDataSource("TaxTemp", taxs);
  615. designer.Process();
  616. string fileName = "WageSheetTaxFile/个税模板" + DateTime.Now.ToString("yyyyMMddHHmmss") + ".xlsx";
  617. string path = AppSettingsHelper.Get("ExcelBasePath");
  618. designer.Workbook.Save(path + fileName);
  619. designer = null;
  620. string excelPath = AppSettingsHelper.Get("ExcelFtpPath") + fileName;
  621. string url = AppSettingsHelper.Get("ExcelBaseUrl");
  622. string fileUrl = url + excelPath;
  623. return Ok(JsonView(true, "操作成功!", new { FileUrl = fileUrl }));
  624. }
  625. }
  626. return Ok(JsonView(false, "操作失败!"));
  627. }
  628. /// <summary>
  629. /// 上传个税
  630. /// </summary>
  631. /// <returns></returns>
  632. [HttpPost]
  633. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  634. public async Task<IActionResult> UploadTax(IFormFile file)
  635. {
  636. try
  637. {
  638. var yearMonth = Request.Headers["YearMonth"].ToString();
  639. //string yearMonth = "2023-10";
  640. string ymFormat = "yyyy-MM";
  641. DateTime yearMonthDt;
  642. bool yearMonthDtIsValid = DateTime.TryParseExact(yearMonth, ymFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out yearMonthDt);
  643. if (!yearMonthDtIsValid) return Ok(JsonView(false, "年月格式错误!正确时间格式:yyyy-MM "));
  644. if (file != null)
  645. {
  646. var fileDir = AppSettingsHelper.Get("WageSheetExcelFptPath");
  647. //文件名称
  648. string projectFileName = file.FileName;
  649. //上传的文件的路径
  650. string filePath = "";
  651. if (!Directory.Exists(fileDir))
  652. {
  653. Directory.CreateDirectory(fileDir);
  654. }
  655. //上传的文件的路径
  656. filePath = fileDir + $@"\{projectFileName}";
  657. if (System.IO.File.Exists(filePath))
  658. {
  659. //删除文件
  660. System.IO.File.Delete(filePath);
  661. }
  662. using (FileStream fs = System.IO.File.Create(filePath))
  663. {
  664. file.CopyTo(fs);
  665. fs.Flush();
  666. }
  667. if (System.IO.File.Exists(filePath))
  668. {
  669. Workbook book = new Workbook(filePath);
  670. DataSet dataSet = new DataSet();
  671. if (book.Worksheets.Count > 0)
  672. {
  673. var sheet = book.Worksheets[0];
  674. if (sheet != null)
  675. {
  676. // sheets 中的数据必须存在
  677. if (sheet.Cells.MaxDataRow != -1 && sheet.Cells.MaxDataColumn != -1)
  678. {
  679. // 方法 ExportDataTable 的参数说明
  680. // 要导出的第一个单元格的行号。
  681. // 要导出的第一个单元格的列号。
  682. // 要导入的行数。
  683. // 要导入的列数。
  684. // 指示第一行的数据是否导出到DataTable的列名。
  685. DataTable dataTable = sheet.Cells.ExportDataTable(0, 0, sheet.Cells.MaxDataRow + 1, sheet.Cells.MaxDataColumn + 1, true);
  686. dataSet.Tables.Add(dataTable);
  687. DataTable taxData = dataSet.Tables[0];
  688. //公司部门
  689. string sql = string.Format(@"Select row_number() over(order by pm_ws.Id) as Row_Number,
  690. sc.Id as CompanyId,sc.CompanyName,sd.Id as DepId,sd.DepName,
  691. sys_u1.CnName Name,sys_u2.CnName LastUpdateUserName,pm_ws.*
  692. From Pm_WageSheet pm_ws
  693. Left Join Sys_Users sys_u1 On pm_ws.UserId = sys_u1.Id
  694. Left Join Sys_Users sys_u2 On pm_ws.LastUpdateUserId = sys_u2.Id
  695. Left Join Sys_Company sc On sys_u1.companyId = sc.Id
  696. Left Join Sys_Department sd On sys_u1.DepId = sd.Id
  697. Where pm_ws.IsDel = 0 And pm_ws.YearMonth = '{0}'
  698. Order By UserId Asc ", yearMonth);
  699. var wageSheetList = await _wageSheetRep._sqlSugar.SqlQueryable<WageSheetInfoView>(sql).ToListAsync();
  700. if (wageSheetList.Count <= 0)
  701. {
  702. return Ok(JsonView(false, yearMonth + "工资数据不存在,请先添加工资数据!"));
  703. }
  704. for (int i = 0; i < taxData.Rows.Count; i++)
  705. {
  706. string name = taxData.Rows[i][0].ToString().Trim();
  707. List<WageSheetInfoView> wageSheets = new List<WageSheetInfoView>();
  708. wageSheets = wageSheetList.Where(it => it.Name.Equals(name)).ToList();
  709. if (wageSheets.Count > 0)
  710. {
  711. wageSheetList.Where(it => it.Name.Equals(name))
  712. .Select(it =>
  713. {
  714. //修改 绩效不等于0.00M的数据
  715. decimal oldTax = it.WithholdingTax;
  716. decimal newTax = Convert.ToDecimal(taxData.Rows[i][1].ToString());
  717. it.WithholdingTax = newTax;
  718. it.TotalRealHair = it.Should - it.TotalDeductions - newTax;
  719. return it;
  720. })
  721. .ToList();
  722. }
  723. }
  724. List<Pm_WageSheet> wageSheets1 = new List<Pm_WageSheet>();
  725. wageSheets1 = _mapper.Map<List<Pm_WageSheet>>(wageSheetList);
  726. var updateStatus = _wageSheetRep._sqlSugar
  727. .Updateable(wageSheets1)
  728. .UpdateColumns(it => new { it.WithholdingTax,it.TotalRealHair})
  729. .ExecuteCommand();
  730. if (updateStatus<0)
  731. {
  732. return Ok(JsonView(false, "操作失败!"));
  733. }
  734. if (System.IO.File.Exists(filePath))
  735. {
  736. //删除文件
  737. System.IO.File.Delete(filePath);
  738. }
  739. return Ok(JsonView(true, "操作成功!"));
  740. }
  741. }
  742. else
  743. {
  744. return Ok(JsonView(false, "工作薄没有数据!"));
  745. }
  746. }
  747. }
  748. return Ok(JsonView(true, "上传成功!", projectFileName));
  749. }
  750. else
  751. {
  752. return Ok(JsonView(false, "上传失败!"));
  753. }
  754. }
  755. catch (Exception ex)
  756. {
  757. return Ok(JsonView(false, "程序错误!"));
  758. throw;
  759. }
  760. return Ok(JsonView(true, "操作成功!"));
  761. }
  762. /// <summary>
  763. /// 打卡记录测试
  764. /// </summary>
  765. /// <returns></returns>
  766. [HttpPost]
  767. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  768. public async Task<IActionResult> Test(string startDt,string endDt)
  769. {
  770. UserIdListView userIdListView = await _qiYeWeChatApiService.GetUserIdListAsync();
  771. if (userIdListView.errcode != 0)
  772. {
  773. _result.Msg = "【企业微信】【打卡】【获取员工ID】【Msg】" + userIdListView.errmsg;
  774. return Ok(JsonView(false, _result.Msg));
  775. }
  776. List<string> qyWhchatIdList = new List<string>();
  777. qyWhchatIdList = userIdListView.dept_user.Select(it => it.userid).ToList();
  778. var data = await _qiYeWeChatApiService.GetCheckinDataAsync(qyWhchatIdList,2,Convert.ToDateTime(startDt), Convert.ToDateTime(endDt));
  779. return Ok(JsonView(true, "操作成功!", data.checkindata));
  780. }
  781. /// <summary>
  782. /// 审批详情
  783. /// </summary>
  784. /// <returns></returns>
  785. [HttpPost]
  786. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  787. public async Task<IActionResult> PostApprovalDetailAsync(string spNo)
  788. {
  789. if (string.IsNullOrEmpty(spNo))
  790. {
  791. return Ok(JsonView(false, "审批单号不能为空!!"));
  792. }
  793. var data = await _qiYeWeChatApiService.GetApprovalDetailAsync(spNo);
  794. return Ok(JsonView(true, "操作成功!", data));
  795. }
  796. #endregion
  797. #region 任务单
  798. /// <summary>
  799. /// 任务分配
  800. /// 基础数据源
  801. /// </summary>
  802. /// <returns></returns>
  803. [HttpPost]
  804. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  805. public async Task<IActionResult> PostTaskAllocationInit(TaskAllocationInitDto _dto)
  806. {
  807. try
  808. {
  809. #region 参数验证
  810. if (_dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
  811. if (_dto.PageId < 1) _dto.PageId = 172; //任务指派Id
  812. PageFunAuthViewBase pageFunAuthView = new PageFunAuthViewBase();
  813. #region 页面操作权限验证
  814. pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(_dto.UserId, _dto.PageId);
  815. if (pageFunAuthView.CheckAuth == 0) return Ok(JsonView(false, "您没有查看权限!"));
  816. #endregion
  817. #endregion
  818. var _view = await _taskAllocationRep._Init(_dto.PortType, _dto.UserId);
  819. if (_view.Code==0)
  820. {
  821. return Ok(JsonView(true, "查询成功!", _view.Data));
  822. }
  823. return Ok(JsonView(false, _view.Msg));
  824. }
  825. catch (Exception ex)
  826. {
  827. return Ok(JsonView(false, ex.Message));
  828. }
  829. }
  830. /// <summary>
  831. /// 任务分配
  832. /// page
  833. /// </summary>
  834. /// <returns></returns>
  835. [HttpPost]
  836. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  837. public async Task<IActionResult> PostTaskAllocationPage(TaskAllocationPageDto _dto)
  838. {
  839. try
  840. {
  841. #region 参数验证
  842. if (_dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
  843. if (_dto.PageId < 1) _dto.PageId = 172; //任务指派Id
  844. PageFunAuthViewBase pageFunAuthView = new PageFunAuthViewBase();
  845. #region 页面操作权限验证
  846. pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(_dto.UserId, _dto.PageId);
  847. if (pageFunAuthView.CheckAuth == 0) return Ok(JsonView(false, "您没有查看权限!"));
  848. #endregion
  849. #endregion
  850. string whereSql = "";
  851. #region 分页参数处理
  852. //类型处理
  853. if (_dto.Type == 0) whereSql = "";
  854. else if (_dto.Type == 1) //1 由我指派
  855. {
  856. whereSql = string.Format(@" And ta.CreateUserId = {0} And (Select COUNT(1) As PeopleNumber From Pm_TaskRelevanceUser Where IsDel = 0 And ta.Id = TAId And UserId = {0}) > 0", _dto.UserId);
  857. }
  858. else if (_dto.Type == 2)// 2 指派给我
  859. {
  860. whereSql = string.Format(@" And (Select COUNT(1) As PeopleNumber From Pm_TaskRelevanceUser Where IsDel = 0 And ta.Id = TAId And UserId = {0}) > 0", _dto.UserId);
  861. }
  862. //状态 -1 全部 0 未开始 1 进行中 2 待审核 3 未完成 4 已完成
  863. if (_dto.Status == -1) //全部
  864. {
  865. whereSql += "";
  866. }
  867. else
  868. {
  869. whereSql += string.Format(@" And ta.Status = {0} ", _dto.Status);
  870. }
  871. //任务名称
  872. if (!string.IsNullOrEmpty(_dto.TaskName))
  873. {
  874. whereSql += string.Format(@" And ta.TaskName Like '%{0}%' ", _dto.TaskName);
  875. }
  876. #endregion
  877. string pageSql = string.Format(@"Select * From(
  878. Select ROW_NUMBER() OVER(ORDER BY ta.CreateTime Desc) AS RowNumber,
  879. ta.Id,ta.TaskName,ta.TaskPriority,d.DepName,di.TeamName,ta.Status,
  880. ta.PredictBeginTime,ta.PredictEndTime,u.CnName As CreateUserName,ta.CreateTime,
  881. (SELECT STUFF(
  882. (Select ',' + u.CnName From Pm_TaskRelevanceUser tra
  883. Left Join Sys_Users u On tra.UserId = u.Id
  884. Where tra.Isdel = 0 And tra.TAId = ta.Id
  885. FOR XML PATH('')),1,1,'')) As Participant,
  886. (SELECT STUFF(
  887. (Select ',' + u.CnName From Pm_TaskRelevanceUser tra
  888. Left Join Sys_Users u On tra.UserId = u.Id
  889. Where tra.Isdel = 0 And tra.TAId = ta.Id And tra.TaskStatus = 4
  890. FOR XML PATH('')),1,1,'')) As Consummator
  891. From Pm_TaskAllocation ta
  892. Left Join Sys_Department d On ta.DepId = d.Id
  893. Left Join Grp_DelegationInfo di On ta.DiId = di.Id
  894. Left Join Sys_Users u On ta.CreateUserId = u.Id
  895. Where ta.IsDel = 0 {0} ) As temp ", whereSql);
  896. RefAsync<int> total = 0;//REF和OUT不支持异步,想要真的异步这是最优解
  897. var _view = await _taskAllocationRep._sqlSugar.SqlQueryable<TaskListView>(pageSql).ToPageListAsync(_dto.PageIndex, _dto.PageSize, total);//ToPageAsync
  898. List<int> taskIds = new List<int>();
  899. taskIds = _view.Select(it => it.Id).ToList();
  900. string taskerSql = string.Format(@"Select tau.TAId,tau.Id,u.CnName As UserName,tau.BeginTime,tau.OverTime,tau.TaskStatus,
  901. tau.Cause,tau.Score,tau.Remark As ScoreRemark,tau.CreateUserId As TaskCreateUserId
  902. From Pm_TaskRelevanceUser tau
  903. Left Join Sys_Users u On tau.UserId = u.Id
  904. Where tau.IsDel = 0");
  905. var taskerData = await _taskAllocationRep._sqlSugar.SqlQueryable<TaskerDetailsView>(taskerSql).Where(it => taskIds.Contains(it.TAId)).ToListAsync();
  906. foreach (var item in _view)
  907. {
  908. item.TaskerDetails = taskerData.Where(it => it.TAId == item.Id).ToList();
  909. }
  910. return Ok(JsonView(true, "查询成功!", _view, total));
  911. }
  912. catch (Exception ex)
  913. {
  914. return Ok(JsonView(false, ex.Message));
  915. }
  916. }
  917. /// <summary>
  918. /// 任务分配
  919. /// 详情
  920. /// </summary>
  921. /// <returns></returns>
  922. [HttpPost]
  923. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  924. public async Task<IActionResult> PostTaskAllocationDetails(TaskAllocationDetailsDto _dto)
  925. {
  926. try
  927. {
  928. #region 参数验证
  929. if (_dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
  930. if (_dto.PageId < 1) _dto.PageId = 172; //任务指派Id
  931. PageFunAuthViewBase pageFunAuthView = new PageFunAuthViewBase();
  932. #region 页面操作权限验证
  933. pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(_dto.UserId, _dto.PageId);
  934. if (pageFunAuthView.CheckAuth == 0) return Ok(JsonView(false, "您没有查看权限!"));
  935. #endregion
  936. #endregion
  937. var _view = await _taskAllocationRep._Details(_dto.PortType, _dto.Id);
  938. if (_view.Code == 0)
  939. {
  940. return Ok(JsonView(true, "查询成功!", _view.Data));
  941. }
  942. return Ok(JsonView(false, _view.Msg));
  943. }
  944. catch (Exception ex)
  945. {
  946. return Ok(JsonView(false, ex.Message));
  947. }
  948. }
  949. /// <summary>
  950. /// 任务分配
  951. /// Add Or Edit
  952. /// </summary>
  953. /// <returns></returns>
  954. [HttpPost]
  955. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  956. public async Task<IActionResult> PostTaskAllocationAddOrEdit(TaskAllocationAddOrEditDto _dto)
  957. {
  958. try
  959. {
  960. #region 参数验证
  961. if (_dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
  962. if (_dto.PageId < 1) _dto.PageId = 172; //任务指派Id
  963. PageFunAuthViewBase pageFunAuthView = new PageFunAuthViewBase();
  964. #region 页面操作权限验证
  965. pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(_dto.UserId, _dto.PageId);
  966. if (_dto.Id == 0)
  967. {
  968. if (pageFunAuthView.AddAuth == 0) return Ok(JsonView(false, "您没有添加权限!"));
  969. }
  970. else if (_dto.Id > 0)
  971. {
  972. if (pageFunAuthView.EditAuth == 0) return Ok(JsonView(false, "您没有编辑权限!"));
  973. }
  974. #endregion
  975. #endregion
  976. var _view = await _taskAllocationRep._AddOrEdit(_dto);
  977. if (_view.Code == 0)
  978. {
  979. return Ok(JsonView(true, "操作成功!"));
  980. }
  981. return Ok(JsonView(false, _view.Msg));
  982. }
  983. catch (Exception ex)
  984. {
  985. return Ok(JsonView(false, ex.Message));
  986. }
  987. }
  988. /// <summary>
  989. /// 任务分配
  990. /// 状态任务归属人详情
  991. /// </summary>
  992. /// <returns></returns>
  993. [HttpPost]
  994. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  995. public async Task<IActionResult> PostTaskAllocationTaskerDetails(TaskerDetailsDto _dto)
  996. {
  997. try
  998. {
  999. var _view = await _taskAllocationRep._TaskerDetails( _dto.Id);
  1000. if (_view.Code == 0)
  1001. {
  1002. return Ok(JsonView(true, "操作成功!", _view.Data));
  1003. }
  1004. return Ok(JsonView(false, _view.Msg));
  1005. }
  1006. catch (Exception ex)
  1007. {
  1008. return Ok(JsonView(false, ex.Message));
  1009. }
  1010. }
  1011. /// <summary>
  1012. /// 任务分配
  1013. /// 状态任务归属人设置开始状态
  1014. /// </summary>
  1015. /// <returns></returns>
  1016. [HttpPost]
  1017. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  1018. public async Task<IActionResult> PostTaskAllocationSetStartStatus(TaskerStatusDto _dto)
  1019. {
  1020. try
  1021. {
  1022. var _view = await _taskAllocationRep._TaskerSetStartStatus(_dto.UserId, _dto.Id);
  1023. if (_view.Code == 0)
  1024. {
  1025. return Ok(JsonView(true, "操作成功!"));
  1026. }
  1027. return Ok(JsonView(false, _view.Msg));
  1028. }
  1029. catch (Exception ex)
  1030. {
  1031. return Ok(JsonView(false, ex.Message));
  1032. }
  1033. }
  1034. /// <summary>
  1035. /// 任务分配
  1036. /// 状态任务归属人设置完成状态
  1037. /// </summary>
  1038. /// <returns></returns>
  1039. [HttpPost]
  1040. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  1041. public async Task<IActionResult> PostTaskAllocationSetOverStatus(TaskerStatusDto _dto)
  1042. {
  1043. try
  1044. {
  1045. var _view = await _taskAllocationRep._TaskerSetOverStatus(_dto.UserId, _dto.Id);
  1046. if (_view.Code == 0)
  1047. {
  1048. return Ok(JsonView(true, "操作成功!"));
  1049. }
  1050. return Ok(JsonView(false, _view.Msg));
  1051. }
  1052. catch (Exception ex)
  1053. {
  1054. return Ok(JsonView(false, ex.Message));
  1055. }
  1056. }
  1057. /// <summary>
  1058. /// 任务分配
  1059. /// 设置知晓状态
  1060. /// </summary>
  1061. /// <returns></returns>
  1062. [HttpPost]
  1063. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  1064. public async Task<IActionResult> PostTaskAllocationSetHaveStatus(TaskAllocationStatusDto _dto)
  1065. {
  1066. try
  1067. {
  1068. var _view = await _taskAllocationRep._TaskSetHaveStatus(_dto.SubId);
  1069. if (_view.Code == 0)
  1070. {
  1071. return Ok(JsonView(true, "操作成功!"));
  1072. }
  1073. return Ok(JsonView(false, _view.Msg));
  1074. }
  1075. catch (Exception ex)
  1076. {
  1077. return Ok(JsonView(false, ex.Message));
  1078. }
  1079. }
  1080. /// <summary>
  1081. /// 任务分配
  1082. /// 确认任务是否可操作完成
  1083. /// </summary>
  1084. /// <returns></returns>
  1085. [HttpPost]
  1086. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  1087. public async Task<IActionResult> PostTaskAllocationIsConfirmCompletion(TaskAllocationScoreDto _dto)
  1088. {
  1089. try
  1090. {
  1091. #region 参数验证
  1092. if (_dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
  1093. if (_dto.PageId < 1) _dto.PageId = 172; //任务指派Id
  1094. PageFunAuthViewBase pageFunAuthView = new PageFunAuthViewBase();
  1095. #region 页面操作权限验证
  1096. pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(_dto.UserId, _dto.PageId);
  1097. if (pageFunAuthView.EditAuth == 0) return Ok(JsonView(false, "您没有编辑权限!"));
  1098. #endregion
  1099. #endregion
  1100. var _view = await _taskAllocationRep._TaskConfirmCompletion(_dto.PortType, _dto.Id);
  1101. if (_view.Code == 0)
  1102. {
  1103. return Ok(JsonView(true, "操作成功!"));
  1104. }
  1105. return Ok(JsonView(false, _view.Msg));
  1106. }
  1107. catch (Exception ex)
  1108. {
  1109. return Ok(JsonView(false, ex.Message));
  1110. }
  1111. }
  1112. /// <summary>
  1113. /// 任务分配
  1114. /// 任务确认完成
  1115. /// </summary>
  1116. /// <returns></returns>
  1117. [HttpPost]
  1118. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  1119. public async Task<IActionResult> PostTaskAllocationConfirmCompletion(TaskAllocationConfirmCompletionDto _dto)
  1120. {
  1121. try
  1122. {
  1123. #region 参数验证
  1124. if (_dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
  1125. if (_dto.PageId < 1) _dto.PageId = 172; //任务指派Id
  1126. PageFunAuthViewBase pageFunAuthView = new PageFunAuthViewBase();
  1127. #region 页面操作权限验证
  1128. pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(_dto.UserId, _dto.PageId);
  1129. if (pageFunAuthView.EditAuth == 0) return Ok(JsonView(false, "您没有编辑权限!"));
  1130. #endregion
  1131. #endregion
  1132. var _view = await _taskAllocationRep._TaskConfirmCompletion(_dto.PortType,_dto.Id);
  1133. if (_view.Code == 0)
  1134. {
  1135. return Ok(JsonView(true, "操作成功!"));
  1136. }
  1137. return Ok(JsonView(false, _view.Msg));
  1138. }
  1139. catch (Exception ex)
  1140. {
  1141. return Ok(JsonView(false, ex.Message));
  1142. }
  1143. }
  1144. /// <summary>
  1145. /// 任务分配
  1146. /// 任务评分
  1147. /// </summary>
  1148. /// <returns></returns>
  1149. [HttpPost]
  1150. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  1151. public async Task<IActionResult> PostTaskAllocationScore(TaskAllocationScoreDto _dto)
  1152. {
  1153. try
  1154. {
  1155. #region 参数验证
  1156. if (_dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
  1157. if (_dto.PageId < 1) _dto.PageId = 172; //任务指派Id
  1158. PageFunAuthViewBase pageFunAuthView = new PageFunAuthViewBase();
  1159. #region 页面操作权限验证
  1160. pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(_dto.UserId, _dto.PageId);
  1161. if (pageFunAuthView.EditAuth == 0) return Ok(JsonView(false, "您没有编辑权限!"));
  1162. #endregion
  1163. #endregion
  1164. var _view = await _taskAllocationRep._TaskScore(_dto);
  1165. if (_view.Code == 0)
  1166. {
  1167. return Ok(JsonView(true, "操作成功!"));
  1168. }
  1169. return Ok(JsonView(false, _view.Msg));
  1170. }
  1171. catch (Exception ex)
  1172. {
  1173. return Ok(JsonView(false, ex.Message));
  1174. }
  1175. }
  1176. #endregion
  1177. }
  1178. }