PersonnelModuleController.cs 105 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516251725182519252025212522252325242525252625272528252925302531
  1. using Aspose.Cells;
  2. using FluentValidation;
  3. using Microsoft.AspNetCore.SignalR;
  4. using OASystem.API.OAMethodLib;
  5. using OASystem.API.OAMethodLib.Hub.HubClients;
  6. using OASystem.API.OAMethodLib.Hub.Hubs;
  7. using OASystem.API.OAMethodLib.QiYeWeChatAPI;
  8. using OASystem.API.OAMethodLib.Quartz.Business;
  9. using OASystem.Domain.Dtos.Groups;
  10. using OASystem.Domain.Dtos.PersonnelModule;
  11. using OASystem.Domain.Entities.PersonnelModule;
  12. using OASystem.Domain.ViewModels.PersonnelModule;
  13. using OASystem.Domain.ViewModels.QiYeWeChat;
  14. using OASystem.Infrastructure.Repositories.PersonnelModule;
  15. using System.Collections;
  16. using System.Data;
  17. using System.Diagnostics;
  18. using System.Globalization;
  19. using static OASystem.API.OAMethodLib.JWTHelper;
  20. namespace OASystem.API.Controllers
  21. {
  22. /// <summary>
  23. /// 人事模块
  24. /// </summary>
  25. [Route("api/[controller]/[action]")]
  26. public class PersonnelModuleController : ControllerBase
  27. {
  28. private Result _result;
  29. private readonly IMapper _mapper;
  30. private readonly decimal _chengDuMinimumWage = 2100.00M;
  31. private readonly IQiYeWeChatApiService _qiYeWeChatApiService;
  32. private readonly WageSheetRepository _wageSheetRep;
  33. private readonly UsersRepository _usersRep;
  34. private readonly TaskAllocationRepository _taskAllocationRep;
  35. private readonly SqlSugarClient _sqlSugar;
  36. private readonly IHubContext<ChatHub, IChatClient> _hubContext;
  37. private readonly GoodsRepository _goodsRep;
  38. private string url, path;
  39. /// <summary>
  40. /// 初始化
  41. /// </summary>
  42. /// <param name="qiYeWeChatApiService"></param>
  43. /// <param name="wageSheetRep"></param>
  44. /// <param name="usersRep"></param>
  45. /// <param name="mapper"></param>
  46. /// <param name="taskAllocationRep"></param>
  47. /// <param name="hubContext"></param>
  48. /// <param name="goodsRep"></param>
  49. /// <param name="sqlSugar"></param>
  50. public PersonnelModuleController(
  51. IHubContext<ChatHub, IChatClient> hubContext,
  52. IMapper mapper,
  53. IQiYeWeChatApiService qiYeWeChatApiService,
  54. WageSheetRepository wageSheetRep,
  55. UsersRepository usersRep,
  56. TaskAllocationRepository taskAllocationRep,
  57. GoodsRepository goodsRep,
  58. SqlSugarClient sqlSugar
  59. )
  60. {
  61. _mapper = mapper;
  62. _usersRep = usersRep;
  63. _qiYeWeChatApiService = qiYeWeChatApiService;
  64. _wageSheetRep = wageSheetRep;
  65. _result = new Result();
  66. _sqlSugar = sqlSugar;
  67. url = AppSettingsHelper.Get("ExcelBaseUrl");
  68. path = AppSettingsHelper.Get("ExcelBasePath");
  69. if (!System.IO.Directory.Exists(path))
  70. {
  71. System.IO.Directory.CreateDirectory(path);//不存在就创建文件夹
  72. }
  73. this._taskAllocationRep = taskAllocationRep;
  74. _hubContext = hubContext;
  75. _goodsRep = goodsRep;
  76. }
  77. #region 工资表单
  78. /// <summary>
  79. /// 工资 月列表
  80. /// </summary>
  81. /// <returns></returns>
  82. [HttpPost]
  83. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  84. public async Task<IActionResult> GetWageSheetMonth()
  85. {
  86. string sql = string.Format("Select * From Pm_WageIssueWorkingDay Where IsDel = 0 Order By YearMonth Desc");
  87. var data = await _wageSheetRep._sqlSugar.SqlQueryable<WageSheetMonthView>(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> GetWageSheetMonthWorkdays(string startDt, string endDt)
  98. {
  99. //参数处理
  100. var dtFormat = "yyyy-MM-dd";
  101. DateTime startDt1, endDt1;
  102. var startDtIsValid = DateTime.TryParseExact(startDt, dtFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out startDt1);
  103. var endDtIsValid = DateTime.TryParseExact(endDt, dtFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out endDt1);
  104. if (!startDtIsValid) return Ok(JsonView(false, "开始日期格式错误!正确时间格式:yyyy-MM-dd "));
  105. if (!endDtIsValid) return Ok(JsonView(false, "结束格式错误!正确时间格式:yyyy-MM-dd "));
  106. var sql = string.Format(@"Select * From Sys_Calendar
  107. Where Isdel = 0 And Dt between '{0}' And '{1}'", startDt, endDt);
  108. var data = await _wageSheetRep._sqlSugar.SqlQueryable<CalendarInfoView>(sql).ToListAsync();
  109. return Ok(JsonView(true, "查询成功!", data));
  110. }
  111. /// <summary>
  112. /// 工资 工作日信息
  113. /// 编辑
  114. /// </summary>
  115. /// <returns></returns>
  116. [HttpPost]
  117. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  118. public async Task<IActionResult> GetWageSheetMonthWorkdaysAddOrEdit(WageSheetMonthWorkdaysAddOrEditDto dto)
  119. {
  120. //参数处理
  121. string yearFormat = "yyyy-MM";
  122. string dtFormat = "yyyy-MM-dd";
  123. DateTime yearDt, startDt1, endDt1;
  124. bool yearDtIsValid = DateTime.TryParseExact(dto.YearMonth, yearFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out yearDt);
  125. bool startDtIsValid = DateTime.TryParseExact(dto.StartDate, dtFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out startDt1);
  126. bool endDtIsValid = DateTime.TryParseExact(dto.EndDate, dtFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out endDt1);
  127. if (!yearDtIsValid) return Ok(JsonView(false, "年月日期格式错误!正确时间格式:yyyy-MM "));
  128. if (!startDtIsValid) return Ok(JsonView(false, "开始日期格式错误!正确时间格式:yyyy-MM-dd "));
  129. if (!endDtIsValid) return Ok(JsonView(false, "结束格式错误!正确时间格式:yyyy-MM-dd "));
  130. #region 处理数据
  131. Pm_WageIssueWorkingDay pm_WageIssueWorkingDay1 = new Pm_WageIssueWorkingDay();
  132. pm_WageIssueWorkingDay1 = _mapper.Map<Pm_WageIssueWorkingDay>(dto);
  133. List<Sys_Calendar> sys_Calendars = new List<Sys_Calendar>();
  134. sys_Calendars = _mapper.Map<List<Sys_Calendar>>(dto.CalendarInfos);
  135. if (sys_Calendars.Count > 0)
  136. {
  137. sys_Calendars = sys_Calendars.OrderBy(it => it.Dt).ToList();
  138. }
  139. pm_WageIssueWorkingDay1.Workdays = sys_Calendars.Where(it => it.IsWorkDay == true).ToList().Count;
  140. foreach (var item in sys_Calendars)
  141. {
  142. item.Remark = pm_WageIssueWorkingDay1.Remark;
  143. item.CreateUserId = pm_WageIssueWorkingDay1.CreateUserId;
  144. item.CreateTime = pm_WageIssueWorkingDay1.CreateTime;
  145. }
  146. #endregion
  147. var _sqlSugar = _wageSheetRep._sqlSugar;
  148. _sqlSugar.BeginTran();
  149. try
  150. {
  151. List<Sys_Calendar> sys_Calendars_add = new List<Sys_Calendar>();
  152. List<Sys_Calendar> sys_Calendars_update = new List<Sys_Calendar>();
  153. sys_Calendars_add = sys_Calendars.Where(it => it.Id == 0).OrderBy(it => it.Dt).ToList();
  154. sys_Calendars_update = sys_Calendars.Where(it => it.Id != 0).OrderBy(it => it.Dt).ToList();
  155. int add1 = 0;
  156. int upd = 0;
  157. if (sys_Calendars_add.Count > 0)
  158. {
  159. var calendarsAdd = await _sqlSugar.Insertable(sys_Calendars_add).ExecuteReturnIdentityAsync();
  160. if (calendarsAdd < 0)
  161. {
  162. _sqlSugar.RollbackTran();
  163. return Ok(JsonView(false, "工作日/节假日/休息日添加失败!"));
  164. }
  165. }
  166. if (sys_Calendars_update.Count > 0)
  167. {
  168. var calendarsUpdate = await _sqlSugar.Updateable<Sys_Calendar>(sys_Calendars)
  169. .UpdateColumns(it => new { it.Dt, it.IsWorkDay, it.IsHoliDay, it.HoliName })
  170. .WhereColumns(it => it.Id)
  171. .ExecuteCommandAsync();
  172. if (calendarsUpdate < 0)
  173. {
  174. _sqlSugar.RollbackTran();
  175. return Ok(JsonView(false, "工作日/节假日/休息日编辑失败!"));
  176. }
  177. }
  178. var calendarsDatas = await _sqlSugar.Queryable<Sys_Calendar>()
  179. .Where(it => Convert.ToDateTime(it.Dt) >= Convert.ToDateTime(dto.StartDate) && Convert.ToDateTime(it.Dt) <= Convert.ToDateTime(dto.EndDate)).ToListAsync();
  180. if (calendarsDatas.Count < 0)
  181. {
  182. _sqlSugar.RollbackTran();
  183. return Ok(JsonView(false, "日期包暂无工作日/节假日/休息日的信息!"));
  184. }
  185. //月份表是否存在
  186. Pm_WageIssueWorkingDay pm_WageIssueWorkingDay = new Pm_WageIssueWorkingDay()
  187. {
  188. YearMonth = dto.YearMonth,
  189. StartDate = dto.StartDate,
  190. EndDate = dto.EndDate,
  191. Workdays = calendarsDatas.Where(it => it.IsWorkDay == true).ToList().Count
  192. };
  193. string sql = string.Format("Select * From Pm_WageIssueWorkingDay Where Isdel = 0 And YearMonth='{0}'", dto.YearMonth);
  194. var workdsys = await _sqlSugar.SqlQueryable<Pm_WageIssueWorkingDay>(sql).FirstAsync();
  195. pm_WageIssueWorkingDay.CreateUserId = dto.UserId;
  196. pm_WageIssueWorkingDay.IsDel = 0;
  197. if (workdsys == null) //添加
  198. {
  199. int addId = await _sqlSugar.Insertable(pm_WageIssueWorkingDay).ExecuteReturnIdentityAsync();
  200. if (addId < 0)
  201. {
  202. _sqlSugar.RollbackTran();
  203. return Ok(JsonView(false, "工作日设置添加失败!"));
  204. }
  205. }
  206. else //更新
  207. {
  208. int updCount = await _sqlSugar.Updateable(pm_WageIssueWorkingDay)
  209. .IgnoreColumns(z => new { z.CreateUserId, z.CreateTime, z.DeleteUserId, z.DeleteTime, z.IsDel })
  210. .WhereColumns(it => it.YearMonth)
  211. .ExecuteCommandAsync();
  212. if (updCount < 0)
  213. {
  214. _sqlSugar.RollbackTran();
  215. return Ok(JsonView(false, "工作日设置编辑失败!"));
  216. }
  217. }
  218. _sqlSugar.CommitTran();
  219. return Ok(JsonView(true, "操作成功!"));
  220. }
  221. catch (Exception ex)
  222. {
  223. _sqlSugar.RollbackTran();
  224. return Ok(JsonView(false, ex.Message));
  225. }
  226. }
  227. /// <summary>
  228. /// 工资表单 基础数据源
  229. /// </summary>
  230. /// <returns></returns>
  231. [HttpPost]
  232. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  233. public async Task<IActionResult> GetWageSheetBasicsDataSource()
  234. {
  235. string companySql = string.Format("Select * From Sys_Company Where IsDel = 0");
  236. var compnayData = await _wageSheetRep._sqlSugar.SqlQueryable<CompanyNameView>(companySql).ToListAsync();
  237. string depSql = string.Format("Select * From Sys_Department Where IsDel = 0");
  238. var depData = await _wageSheetRep._sqlSugar.SqlQueryable<Domain.ViewModels.System.DepartmentView>(depSql).ToListAsync();
  239. //获取OA系统内所有用户
  240. var nameData = await _usersRep.GetUserNameList(1);
  241. if (nameData.Code != 0)
  242. {
  243. return Ok(JsonView(false, nameData.Msg));
  244. }
  245. var data = new
  246. {
  247. compnayData = compnayData,
  248. depData = depData,
  249. userNames = nameData.Data
  250. };
  251. return Ok(JsonView(true, "查询成功!", data));
  252. }
  253. /// <summary>
  254. /// 获取工资发放月份
  255. /// </summary>
  256. /// <param name="dto"></param>
  257. /// <returns></returns>
  258. [HttpPost]
  259. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  260. public async Task<IActionResult> GetWageYaerMonths(WageYearDto dto)
  261. {
  262. string sql = string.Format(@"Select * From Pm_WageIssueWorkingDay
  263. Where Isdel = 0 And YearMonth Like '%{0}%'
  264. Order By YearMonth Asc", dto.Year);
  265. var data = await _wageSheetRep._sqlSugar.SqlQueryable<WageYearMonthView>(sql).ToListAsync();
  266. return Ok(JsonView(true, "操作成功!", data));
  267. }
  268. /// <summary>
  269. /// 获取工资表单
  270. /// </summary>
  271. /// <param name="dto"></param>
  272. /// <returns></returns>
  273. [HttpPost]
  274. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  275. public async Task<IActionResult> GetWageSheetList(WageSheetListDto dto)
  276. {
  277. //参数处理
  278. string ymFormat = "yyyy-MM";
  279. DateTime yearMonthDt;
  280. bool yearMonthDttIsValid = DateTime.TryParseExact(dto.YearMonth, ymFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out yearMonthDt);
  281. if (!yearMonthDttIsValid)
  282. {
  283. _result.Msg = "年月格式错误!正确时间格式:yyyy-MM ";
  284. return Ok(JsonView(false, _result.Msg));
  285. }
  286. //获取月工资数据
  287. string yearMonth = yearMonthDt.ToString("yyyy-MM");
  288. if (dto.PortType == 1)
  289. {
  290. _result = await _wageSheetRep.Get_WageSheet_ListByYearMonthAsync(yearMonth);
  291. if (_result.Code != 0)
  292. {
  293. return Ok(JsonView(false, _result.Msg));
  294. }
  295. }
  296. else if (dto.PortType == 2)
  297. { }
  298. else if (dto.PortType == 3)
  299. { }
  300. else
  301. {
  302. return Ok(JsonView(false, "请选择正确的端口参数"));
  303. }
  304. return Ok(JsonView(true, _result.Msg, _result.Data));
  305. }
  306. /// <summary>
  307. /// 获取工资 详情
  308. /// </summary>
  309. /// <param name="dto"></param>
  310. /// <returns></returns>
  311. [HttpPost]
  312. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  313. public async Task<IActionResult> GetWageSheetById(WageSheetInfoDto dto)
  314. {
  315. if (dto.PortType == 1)
  316. {
  317. _result = await _wageSheetRep.Get_WageSheet_InfoByIdAsync(dto.Id);
  318. if (_result.Code != 0)
  319. {
  320. return Ok(JsonView(false, _result.Msg));
  321. }
  322. }
  323. else if (dto.PortType == 2)
  324. { }
  325. else if (dto.PortType == 3)
  326. { }
  327. else
  328. {
  329. return Ok(JsonView(false, "请选择正确的端口参数"));
  330. }
  331. return Ok(JsonView(true, _result.Msg, _result.Data));
  332. }
  333. /// <summary>
  334. /// 人事模块 工资表单 删除
  335. /// </summary>
  336. /// <param name="dto"></param>
  337. /// <returns></returns>
  338. [HttpPost]
  339. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  340. public async Task<IActionResult> PostWageSheetDel(WageDelDto dto)
  341. {
  342. try
  343. {
  344. _result = await _wageSheetRep.Post_WageSheet_DelAsync(dto);
  345. if (_result.Code != 0)
  346. {
  347. return Ok(JsonView(false, _result.Msg));
  348. }
  349. }
  350. catch (Exception ex)
  351. {
  352. return Ok(JsonView(false, ex.Message));
  353. }
  354. return Ok(JsonView(true, _result.Msg, _result.Data));
  355. }
  356. /// <summary>
  357. /// 人事模块 工资表单 添加 Or 修改
  358. /// </summary>
  359. /// <param name="dto"></param>
  360. /// <returns></returns>
  361. [HttpPost]
  362. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  363. public async Task<IActionResult> PostWageSheetAddOrEdit(WageAddOrEditDto dto)
  364. {
  365. try
  366. {
  367. Pm_WageSheet pm_WageSheet = new Pm_WageSheet();
  368. pm_WageSheet = _mapper.Map<Pm_WageSheet>(dto);
  369. pm_WageSheet.LastUpdateUserId = dto.CreateUserId;
  370. #region 计算工资
  371. //月工资
  372. decimal salary = pm_WageSheet.Basic + pm_WageSheet.Floats + pm_WageSheet.PostAllowance + pm_WageSheet.InformationSecurityFee + pm_WageSheet.OtherSubsidies;
  373. //扣款合计
  374. decimal totalDeduction = pm_WageSheet.SickLeave + pm_WageSheet.SomethingFalse + pm_WageSheet.LateTo + pm_WageSheet.LeaveEarly + pm_WageSheet.Absenteeism + pm_WageSheet.NotPunch +
  375. pm_WageSheet.ReservedFunds + pm_WageSheet.WithholdingInsurance + pm_WageSheet.OtherDeductions + pm_WageSheet.OtherDeductions;
  376. //实发合计 不含个税
  377. if (pm_WageSheet.RegularDays >= pm_WageSheet.WorkDays)
  378. {
  379. pm_WageSheet.RegularDays = pm_WageSheet.WorkDays;
  380. salary = salary + pm_WageSheet.Mealsupplement + pm_WageSheet.OtherHandle;
  381. }
  382. else
  383. {
  384. if (dto.UserId == 21) //21==张海麟
  385. {
  386. salary = salary + pm_WageSheet.Mealsupplement + pm_WageSheet.OtherHandle;
  387. }
  388. else
  389. {
  390. salary = PayrollComputation.ConvertToDecimal(salary / pm_WageSheet.WorkDays * pm_WageSheet.RegularDays + pm_WageSheet.Mealsupplement + pm_WageSheet.OtherHandle);
  391. }
  392. }
  393. decimal actualTotal = salary - totalDeduction;
  394. pm_WageSheet.Should = salary;
  395. pm_WageSheet.TotalDeductions = totalDeduction;
  396. pm_WageSheet.TotalRealHair = actualTotal - pm_WageSheet.WithholdingTax;
  397. pm_WageSheet.AfterTax = actualTotal - pm_WageSheet.WithholdingTax;
  398. #endregion
  399. _result = await _wageSheetRep.Post_WageSheet_AddOrEditAsync(dto, pm_WageSheet);
  400. if (_result.Code != 0)
  401. {
  402. return Ok(JsonView(false, _result.Msg));
  403. }
  404. }
  405. catch (Exception ex)
  406. {
  407. return Ok(JsonView(false, ex.Message));
  408. }
  409. return Ok(JsonView(true, _result.Msg, _result.Data));
  410. }
  411. /// <summary>
  412. /// 计算工资
  413. /// </summary>
  414. /// <returns></returns>
  415. [HttpPost]
  416. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  417. public async Task<IActionResult> SalaryCalculatorAsync(SalaryCalculatorDto dto)
  418. {
  419. Result result = new Result();
  420. Stopwatch sw = new Stopwatch();
  421. sw.Start();
  422. //参数处理
  423. string ymFormat = "yyyy-MM";
  424. string dtFormat = "yyyy-MM-dd";
  425. DateTime yearMonthDt, startDt, endDt;
  426. bool yearMonthDtIsValid = DateTime.TryParseExact(dto.yearMonth, ymFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out yearMonthDt);
  427. bool startDtIsValid = DateTime.TryParseExact(dto.startDt, dtFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out startDt);
  428. bool endDtIsValid = DateTime.TryParseExact(dto.endDt, dtFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out endDt);
  429. if (!yearMonthDtIsValid) return Ok(JsonView(false, "年月格式错误!正确时间格式:yyyy-MM "));
  430. if (!startDtIsValid) return Ok(JsonView(false, "开始日期格式错误!正确时间格式:yyyy-MM-dd "));
  431. if (!endDtIsValid) return Ok(JsonView(false, "结束格式错误!正确时间格式:yyyy-MM-dd "));
  432. string thisYearMonth = dto.yearMonth;
  433. string preYearMonth = yearMonthDt.AddMonths(-1).ToString("yyyy-MM");
  434. //计算本月工资起止时间 比如是2月的1号-28号,那就是2月1号的零点到3月1号的零点
  435. DateTime thisStartDt = startDt;
  436. DateTime thisEndDt = endDt; //
  437. //本月工资是否有数据 有数据则不计算
  438. result = await _wageSheetRep.Get_WageSheet_ListByYearMonthAsync(thisYearMonth);
  439. if (result.Code == 0)
  440. {
  441. return Ok(JsonView(false, thisYearMonth + " 工资数据已存在,若无人员工资请手动添加!"));
  442. }
  443. //获取上个月工资信息
  444. List<Pm_WageSheet> preWageSheetItems = await _wageSheetRep._sqlSugar.Queryable<Pm_WageSheet>().Where(it => it.IsDel == 0 && it.YearMonth == preYearMonth).ToListAsync();
  445. preWageSheetItems = preWageSheetItems.OrderBy(it => it.UserId).ToList();
  446. if (preWageSheetItems.Count <= 0)
  447. {
  448. return Ok(JsonView(false, thisYearMonth + " 上月工资数据不存在,请手动添加!"));
  449. }
  450. //处理上个月同月同人 多条数据
  451. List<Pm_WageSheet> preWageSheetItems1 = new List<Pm_WageSheet>();
  452. preWageSheetItems1 = preWageSheetItems.GroupBy(it => new { it.YearMonth, it.UserId })
  453. .Select(it => it.FirstOrDefault(item => item.Basic != 0))
  454. .ToList();
  455. //获取OA系统内所有用户
  456. List<UserNameView> userNames = _usersRep._sqlSugar.SqlQueryable<UserNameView>("Select Id,CnName From Sys_Users").ToList();
  457. List<Pm_WageSheet> wageSheets = new List<Pm_WageSheet>();
  458. _result = await PayrollComputation.SalaryCalculatorAsync(preWageSheetItems1, userNames, dto.UserId, thisYearMonth, thisStartDt, thisEndDt);
  459. #region 批量添加
  460. if (_result.Code != 0)
  461. {
  462. return Ok(JsonView(false, _result.Msg));
  463. }
  464. wageSheets = _result.Data;
  465. var add = await _wageSheetRep._sqlSugar.Insertable(wageSheets).ExecuteCommandAsync();
  466. if (add <= 0)
  467. {
  468. return Ok(JsonView(false, "操作失败!"));
  469. }
  470. #endregion
  471. #region 处理返回数据
  472. //List <WageSheetItemInfoView> wageSheetItems = new List<WageSheetItemInfoView>();
  473. //wageSheetItems = _mapper.Map<List<WageSheetItemInfoView>>(wageSheets);
  474. //wageSheetItems = wageSheetItems.Select(it =>
  475. // {
  476. // UserNameView? uName1 = new UserNameView();
  477. // UserNameView? uName2 = new UserNameView();
  478. // uName1 = userNames.Where(it1 => it.UserId == it1.Id).FirstOrDefault();
  479. // if (uName1 != null) it.Name = uName1.CnName;
  480. // uName2 = userNames.Where(it1 => it.LastUpdateUserId == it1.Id).FirstOrDefault();
  481. // if (uName2 != null) it.LastUpdateUserName = uName2.CnName;
  482. // return it; }
  483. // ).ToList();
  484. #endregion
  485. sw.Stop();
  486. return Ok(JsonView(true, "操作成功! 耗时:" + (sw.ElapsedMilliseconds / 1000) + "s"));
  487. }
  488. /// <summary>
  489. /// 计算工资 By YearMonth And UserId
  490. /// </summary>
  491. /// <returns></returns>
  492. [HttpPost]
  493. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  494. public async Task<IActionResult> SalaryCalculatorSingleAsync(SalaryCalculatorSingleDto dto)
  495. {
  496. Result result = new Result();
  497. Stopwatch sw = new Stopwatch();
  498. sw.Start();
  499. //参数处理
  500. string ymFormat = "yyyy-MM";
  501. string ymdFormat = "yyyy-MM-dd";
  502. DateTime yearMonthDt, startDt, endDt;
  503. bool yearMonthDtIsValid = DateTime.TryParseExact(dto.YearMonth, ymFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out yearMonthDt);
  504. bool startDtIsValid = DateTime.TryParseExact(dto.StartDate, ymdFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out startDt);
  505. bool endDtIsValid = DateTime.TryParseExact(dto.EndDate, ymdFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out endDt);
  506. if (!yearMonthDtIsValid) return Ok(JsonView(false, "年月格式错误!正确时间格式:yyyy-MM "));
  507. if (!startDtIsValid) return Ok(JsonView(false, "开始时间格式错误!正确时间格式:yyyy-MM-dd "));
  508. if (!yearMonthDtIsValid) return Ok(JsonView(false, "结束时间格式错误!正确时间格式:yyyy-MM-dd "));
  509. List<Pm_WageSheet> wageSheets = new List<Pm_WageSheet>();
  510. Pm_WageSheet wageSheet = _mapper.Map<Pm_WageSheet>(dto);
  511. 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();
  512. if (wageSheet1 != null)
  513. {
  514. wageSheet.Id = wageSheet1.Id;
  515. }
  516. wageSheets.Add(wageSheet);
  517. //获取OA系统内所有用户
  518. List<UserNameView> userNames = _usersRep._sqlSugar.SqlQueryable<UserNameView>("Select Id,CnName From Sys_Users").ToList();
  519. _result = await PayrollComputation.SalaryCalculatorAsync(wageSheets, userNames, dto.UserId, dto.YearMonth, startDt, endDt);
  520. if (_result.Code != 0)
  521. {
  522. return Ok(JsonView(false, _result.Msg));
  523. }
  524. List<Pm_WageSheet> wageSheets1 = new List<Pm_WageSheet>();
  525. wageSheets1 = _result.Data;
  526. #region 处理返回数据
  527. List<WageSheetInfoView> wageSheetItems = new List<WageSheetInfoView>();
  528. wageSheetItems = _mapper.Map<List<WageSheetInfoView>>(wageSheets1);
  529. wageSheetItems = wageSheetItems.Select(it =>
  530. {
  531. UserNameView? uName1 = new UserNameView();
  532. UserNameView? uName2 = new UserNameView();
  533. uName1 = userNames.Where(it1 => it.UserId == it1.Id).FirstOrDefault();
  534. if (uName1 != null) it.Name = uName1.CnName;
  535. uName2 = userNames.Where(it1 => it.LastUpdateUserId == it1.Id).FirstOrDefault();
  536. if (uName2 != null) it.LastUpdateUserName = uName2.CnName;
  537. return it;
  538. }
  539. ).ToList();
  540. #endregion
  541. sw.Stop();
  542. return Ok(JsonView(true, "操作成功!耗时:" + (sw.ElapsedMilliseconds / 1000) + "s", wageSheetItems[0]));
  543. }
  544. /// <summary>
  545. /// 导出工资单
  546. /// </summary>
  547. /// <returns></returns>
  548. [HttpPost]
  549. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  550. public async Task<IActionResult> ExportWageCard(string yearMonth)
  551. {
  552. Result result = new Result();
  553. Stopwatch sw = new Stopwatch();
  554. sw.Start();
  555. //参数处理
  556. string ymFormat = "yyyy-MM";
  557. DateTime yearMonthDt;
  558. bool yearMonthDtIsValid = DateTime.TryParseExact(yearMonth, ymFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out yearMonthDt);
  559. if (!yearMonthDtIsValid) return Ok(JsonView(false, "年月格式错误!正确时间格式:yyyy-MM "));
  560. //公司部门
  561. string sql = string.Format(@"Select row_number() over(order by pm_ws.Id) as Row_Number,
  562. sc.Id as CompanyId,sc.CompanyName,sd.Id as DepId,sd.DepName,
  563. sys_u1.CnName Name,sys_u2.CnName LastUpdateUserName,pm_ws.*
  564. From Pm_WageSheet pm_ws
  565. Left Join Sys_Users sys_u1 On pm_ws.UserId = sys_u1.Id
  566. Left Join Sys_Users sys_u2 On pm_ws.LastUpdateUserId = sys_u2.Id
  567. Left Join Sys_Company sc On sys_u1.companyId = sc.Id
  568. Left Join Sys_Department sd On sys_u1.DepId = sd.Id
  569. Where pm_ws.IsDel = 0 And pm_ws.YearMonth = '{0}'", yearMonth);
  570. var wageSheetList = await _wageSheetRep._sqlSugar.SqlQueryable<ExportWageSheetItemView>(sql).ToListAsync();
  571. if (wageSheetList.Count <= 0)
  572. {
  573. return Ok(JsonView(false, yearMonth + "暂无工资数据!"));
  574. }
  575. decimal SumPrice = 0.00M;
  576. foreach (var item in wageSheetList)
  577. {
  578. SumPrice += item.AfterTax;
  579. }
  580. WorkbookDesigner designer = new WorkbookDesigner();
  581. designer.Workbook = new Workbook(AppSettingsHelper.Get("ExcelBasePath") + "Template/工资详细清单.xlsx");
  582. designer.Workbook.Worksheets[0].Name = yearMonth + " 工资单";
  583. designer.SetDataSource("WageSheet", wageSheetList);
  584. designer.SetDataSource("YearMonth", yearMonth);
  585. designer.SetDataSource("StartEndDt", wageSheetList[0].StartDate + " - " + wageSheetList[0].EndDate);
  586. designer.SetDataSource("WorkDays", wageSheetList[0].WorkDays);
  587. designer.SetDataSource("SumPrice", SumPrice);
  588. designer.SetDataSource("WageSheetTitle", "工资单");//
  589. designer.Process();
  590. string fileName = "WageCard/" + yearMonth + "_工资单_" + DateTime.Now.ToString("yyyyMMddHHmmss") + ".xlsx";
  591. string path = AppSettingsHelper.Get("ExcelBasePath");
  592. designer.Workbook.Save(path + fileName);
  593. designer = null;
  594. string excelPath = AppSettingsHelper.Get("ExcelFtpPath") + fileName;
  595. string url = AppSettingsHelper.Get("ExcelBaseUrl");
  596. string fileUrl = url + excelPath;
  597. sw.Stop();
  598. return Ok(JsonView(true, "操作成功!耗时:" + (sw.ElapsedMilliseconds / 1000) + "s", new { FileUrl = fileUrl }));
  599. }
  600. /// <summary>
  601. /// 下载个税模板
  602. /// </summary>
  603. /// <returns></returns>
  604. [HttpPost]
  605. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  606. public async Task<IActionResult> WageSheetTaxTemplate()
  607. {
  608. string serverUrl = AppSettingsHelper.Get("WageSheetExcelBaseUrl");
  609. var userData = await _usersRep.GetUserNameList(1);
  610. if (userData.Code == 0)
  611. {
  612. var userNames = userData.Data;
  613. List<string> names = new List<string>();
  614. List<UserNameView> users = new List<UserNameView>();
  615. names.Add("管理员");
  616. names.Add("国交共享号");
  617. names.Add("人事审核号");
  618. names.Add("国交主管号");
  619. List<TaxTemlateViuw> taxs = new List<TaxTemlateViuw>();
  620. users = JsonConvert.DeserializeObject<List<UserNameView>>(JsonConvert.SerializeObject(userNames));
  621. foreach (UserNameView item in users)
  622. {
  623. string uName = item.CnName;
  624. if (!names.Contains(uName))
  625. {
  626. taxs.Add(new TaxTemlateViuw { UserName = item.CnName });
  627. }
  628. }
  629. if (taxs.Count > 0)
  630. {
  631. WorkbookDesigner designer = new WorkbookDesigner();
  632. designer.Workbook = new Workbook(AppSettingsHelper.Get("ExcelBasePath") + "Template/个税导入模板.xlsx");
  633. designer.Workbook.Worksheets[0].Name = "个税模板";
  634. designer.SetDataSource("TaxTemp", taxs);
  635. designer.Process();
  636. string fileName = "WageSheetTaxFile/个税模板" + DateTime.Now.ToString("yyyyMMddHHmmss") + ".xlsx";
  637. string path = AppSettingsHelper.Get("ExcelBasePath");
  638. designer.Workbook.Save(path + fileName);
  639. designer = null;
  640. string excelPath = AppSettingsHelper.Get("ExcelFtpPath") + fileName;
  641. string url = AppSettingsHelper.Get("ExcelBaseUrl");
  642. string fileUrl = url + excelPath;
  643. return Ok(JsonView(true, "操作成功!", new { FileUrl = fileUrl }));
  644. }
  645. }
  646. return Ok(JsonView(false, "操作失败!"));
  647. }
  648. /// <summary>
  649. /// 上传个税
  650. /// </summary>
  651. /// <returns></returns>
  652. [HttpPost]
  653. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  654. public async Task<IActionResult> UploadTax(IFormFile file)
  655. {
  656. try
  657. {
  658. var yearMonth = Request.Headers["YearMonth"].ToString();
  659. //string yearMonth = "2023-10";
  660. string ymFormat = "yyyy-MM";
  661. DateTime yearMonthDt;
  662. bool yearMonthDtIsValid = DateTime.TryParseExact(yearMonth, ymFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out yearMonthDt);
  663. if (!yearMonthDtIsValid) return Ok(JsonView(false, "年月格式错误!正确时间格式:yyyy-MM "));
  664. if (file != null)
  665. {
  666. var fileDir = AppSettingsHelper.Get("WageSheetExcelFptPath");
  667. //文件名称
  668. string projectFileName = file.FileName;
  669. //上传的文件的路径
  670. string filePath = "";
  671. if (!Directory.Exists(fileDir))
  672. {
  673. Directory.CreateDirectory(fileDir);
  674. }
  675. //上传的文件的路径
  676. filePath = fileDir + $@"\{projectFileName}";
  677. if (System.IO.File.Exists(filePath))
  678. {
  679. //删除文件
  680. System.IO.File.Delete(filePath);
  681. }
  682. using (FileStream fs = System.IO.File.Create(filePath))
  683. {
  684. file.CopyTo(fs);
  685. fs.Flush();
  686. }
  687. if (System.IO.File.Exists(filePath))
  688. {
  689. Workbook book = new Workbook(filePath);
  690. DataSet dataSet = new DataSet();
  691. if (book.Worksheets.Count > 0)
  692. {
  693. var sheet = book.Worksheets[0];
  694. if (sheet != null)
  695. {
  696. // sheets 中的数据必须存在
  697. if (sheet.Cells.MaxDataRow != -1 && sheet.Cells.MaxDataColumn != -1)
  698. {
  699. // 方法 ExportDataTable 的参数说明
  700. // 要导出的第一个单元格的行号。
  701. // 要导出的第一个单元格的列号。
  702. // 要导入的行数。
  703. // 要导入的列数。
  704. // 指示第一行的数据是否导出到DataTable的列名。
  705. DataTable dataTable = sheet.Cells.ExportDataTable(0, 0, sheet.Cells.MaxDataRow + 1, sheet.Cells.MaxDataColumn + 1, true);
  706. dataSet.Tables.Add(dataTable);
  707. DataTable taxData = dataSet.Tables[0];
  708. //公司部门
  709. string sql = string.Format(@"Select row_number() over(order by pm_ws.Id) as Row_Number,
  710. sc.Id as CompanyId,sc.CompanyName,sd.Id as DepId,sd.DepName,
  711. sys_u1.CnName Name,sys_u2.CnName LastUpdateUserName,pm_ws.*
  712. From Pm_WageSheet pm_ws
  713. Left Join Sys_Users sys_u1 On pm_ws.UserId = sys_u1.Id
  714. Left Join Sys_Users sys_u2 On pm_ws.LastUpdateUserId = sys_u2.Id
  715. Left Join Sys_Company sc On sys_u1.companyId = sc.Id
  716. Left Join Sys_Department sd On sys_u1.DepId = sd.Id
  717. Where pm_ws.IsDel = 0 And pm_ws.YearMonth = '{0}'
  718. Order By UserId Asc ", yearMonth);
  719. var wageSheetList = await _wageSheetRep._sqlSugar.SqlQueryable<WageSheetInfoView>(sql).ToListAsync();
  720. if (wageSheetList.Count <= 0)
  721. {
  722. return Ok(JsonView(false, yearMonth + "工资数据不存在,请先添加工资数据!"));
  723. }
  724. for (int i = 0; i < taxData.Rows.Count; i++)
  725. {
  726. string name = taxData.Rows[i][0].ToString().Trim();
  727. List<WageSheetInfoView> wageSheets = new List<WageSheetInfoView>();
  728. wageSheets = wageSheetList.Where(it => it.Name.Equals(name)).ToList();
  729. if (wageSheets.Count > 0)
  730. {
  731. wageSheetList.Where(it => it.Name.Equals(name))
  732. .Select(it =>
  733. {
  734. //修改 绩效不等于0.00M的数据
  735. //decimal oldTax = it.WithholdingTax;
  736. var newTax = Convert.ToDecimal(taxData.Rows[i][1].ToString());
  737. it.WithholdingTax = newTax;
  738. it.TotalRealHair = it.Should - it.TotalDeductions - newTax;
  739. return it;
  740. })
  741. .ToList();
  742. }
  743. }
  744. List<Pm_WageSheet> wageSheets1 = new List<Pm_WageSheet>();
  745. wageSheets1 = _mapper.Map<List<Pm_WageSheet>>(wageSheetList);
  746. var updateStatus = _wageSheetRep._sqlSugar
  747. .Updateable(wageSheets1)
  748. .UpdateColumns(it => new { it.WithholdingTax, it.TotalRealHair })
  749. .ExecuteCommand();
  750. if (updateStatus < 0)
  751. {
  752. return Ok(JsonView(false, "操作失败!"));
  753. }
  754. if (System.IO.File.Exists(filePath))
  755. {
  756. //删除文件
  757. System.IO.File.Delete(filePath);
  758. }
  759. return Ok(JsonView(true, "操作成功!"));
  760. }
  761. }
  762. else
  763. {
  764. return Ok(JsonView(false, "工作薄没有数据!"));
  765. }
  766. }
  767. }
  768. return Ok(JsonView(true, "上传成功!", projectFileName));
  769. }
  770. else
  771. {
  772. return Ok(JsonView(false, "上传失败!"));
  773. }
  774. }
  775. catch (Exception ex)
  776. {
  777. return Ok(JsonView(false, "程序错误!"));
  778. throw;
  779. }
  780. return Ok(JsonView(true, "操作成功!"));
  781. }
  782. /// <summary>
  783. /// 打卡记录测试
  784. /// </summary>
  785. /// <returns></returns>
  786. [HttpPost]
  787. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  788. public async Task<IActionResult> Test(string startDt, string endDt, int code)
  789. {
  790. UserIdListView userIdListView = await _qiYeWeChatApiService.GetUserIdListAsync();
  791. if (userIdListView.errcode != 0)
  792. {
  793. _result.Msg = "【企业微信】【打卡】【获取员工ID】【Msg】" + userIdListView.errmsg;
  794. return Ok(JsonView(false, _result.Msg));
  795. }
  796. List<string> qyWhchatIdList = new List<string>();
  797. qyWhchatIdList = userIdListView.dept_user.Select(it => it.userid).ToList();
  798. var data = await _qiYeWeChatApiService.GetCheckinDataAsync(qyWhchatIdList, code, Convert.ToDateTime(startDt), Convert.ToDateTime(endDt));
  799. return Ok(JsonView(true, "操作成功!", data.checkindata));
  800. }
  801. /// <summary>
  802. /// 审批详情
  803. /// </summary>
  804. /// <returns></returns>
  805. [HttpPost]
  806. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  807. public async Task<IActionResult> PostApprovalDetailAsync(string spNo)
  808. {
  809. if (string.IsNullOrEmpty(spNo))
  810. {
  811. return Ok(JsonView(false, "审批单号不能为空!!"));
  812. }
  813. var data = await _qiYeWeChatApiService.GetApprovalDetailAsync(spNo);
  814. return Ok(JsonView(true, "操作成功!", data));
  815. }
  816. #endregion
  817. #region 任务单
  818. /// <summary>
  819. /// 任务分配
  820. /// 基础数据源
  821. /// </summary>
  822. /// <returns></returns>
  823. [HttpPost]
  824. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  825. public async Task<IActionResult> PostTaskAllocationInit(TaskAllocationInitDto dto)
  826. {
  827. try
  828. {
  829. #region 参数验证
  830. if (dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
  831. if (dto.PageId < 1) dto.PageId = 172; //任务指派Id
  832. PageFunAuthViewBase pageFunAuthView = new PageFunAuthViewBase();
  833. #region 页面操作权限验证
  834. pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(dto.UserId, dto.PageId);
  835. if (pageFunAuthView.CheckAuth == 0) return Ok(JsonView(false, "您没有查看权限!"));
  836. #endregion
  837. #endregion
  838. var _view = await _taskAllocationRep._Init(dto.PortType, dto.UserId);
  839. if (_view.Code == 0)
  840. {
  841. return Ok(JsonView(true, "查询成功!", _view.Data));
  842. }
  843. return Ok(JsonView(false, _view.Msg));
  844. }
  845. catch (Exception ex)
  846. {
  847. return Ok(JsonView(false, ex.Message));
  848. }
  849. }
  850. /// <summary>
  851. /// 任务分配
  852. /// page
  853. /// </summary>
  854. /// <returns></returns>
  855. [HttpPost]
  856. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  857. public async Task<IActionResult> PostTaskAllocationPage(TaskAllocationPageDto dto)
  858. {
  859. try
  860. {
  861. #region 参数验证
  862. if (dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
  863. if (dto.PageId < 1) dto.PageId = 172; //任务指派Id
  864. PageFunAuthViewBase pageFunAuthView = new PageFunAuthViewBase();
  865. #region 页面操作权限验证
  866. pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(dto.UserId, dto.PageId);
  867. if (pageFunAuthView.CheckAuth == 0) return Ok(JsonView(false, "您没有查看权限!"));
  868. #endregion
  869. #endregion
  870. string whereSql = "";
  871. #region 分页参数处理
  872. //类型处理
  873. if (dto.Type == 0) whereSql = "";
  874. else if (dto.Type == 1) //1 由我指派
  875. {
  876. whereSql = string.Format(@" And ta.CreateUserId = {0} Or (Select COUNT(1) As PeopleNumber From Pm_TaskRelevanceUser Where IsDel = 0 And ta.Id = TAId And UserId = {0}) > 0", dto.UserId);
  877. }
  878. else if (dto.Type == 2)// 2 指派给我
  879. {
  880. 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);
  881. }
  882. //状态 -1 全部 0 未开始 1 进行中 2 待审核 3 未完成 4 已完成
  883. if (dto.Status == -1) //全部
  884. {
  885. whereSql += "";
  886. }
  887. else
  888. {
  889. whereSql += string.Format(@" And ta.Status = {0} ", dto.Status);
  890. }
  891. //任务名称
  892. if (!string.IsNullOrEmpty(dto.TaskName))
  893. {
  894. whereSql += string.Format(@" And ta.TaskName Like '%{0}%' ", dto.TaskName);
  895. }
  896. #endregion
  897. string pageSql = string.Format(@"Select * From(
  898. Select ROW_NUMBER() OVER(ORDER BY ta.CreateTime Desc) AS RowNumber,
  899. ta.Id,ta.TaskName,ta.TaskPriority,d.DepName,di.TeamName,ta.Status,
  900. ta.PredictBeginTime,ta.PredictEndTime,u.CnName As CreateUserName,ta.CreateTime,
  901. (SELECT STUFF(
  902. (Select ',' + u.CnName From Pm_TaskRelevanceUser tra
  903. Left Join Sys_Users u On tra.UserId = u.Id
  904. Where tra.Isdel = 0 And tra.TAId = ta.Id
  905. FOR XML PATH('')),1,1,'')) As Participant,
  906. (SELECT STUFF(
  907. (Select ',' + u.CnName From Pm_TaskRelevanceUser tra
  908. Left Join Sys_Users u On tra.UserId = u.Id
  909. Where tra.Isdel = 0 And tra.TAId = ta.Id And tra.TaskStatus = 4
  910. FOR XML PATH('')),1,1,'')) As Consummator
  911. From Pm_TaskAllocation ta
  912. Left Join Sys_Department d On ta.DepId = d.Id
  913. Left Join Grp_DelegationInfo di On ta.DiId = di.Id
  914. Left Join Sys_Users u On ta.CreateUserId = u.Id
  915. Where ta.IsDel = 0 {0} ) As temp ", whereSql);
  916. RefAsync<int> total = 0;//REF和OUT不支持异步,想要真的异步这是最优解
  917. var _view = await _taskAllocationRep._sqlSugar.SqlQueryable<TaskListView>(pageSql).ToPageListAsync(dto.PageIndex, dto.PageSize, total);//ToPageAsync
  918. List<int> taskIds = new List<int>();
  919. taskIds = _view.Select(it => it.Id).ToList();
  920. string taskerSql = string.Format(@"Select tau.TAId,tau.Id,tau.UserId,u.CnName As UserName,tau.BeginTime,tau.OverTime,tau.TaskStatus,
  921. tau.Cause,tau.Score,tau.Remark As ScoreRemark,tau.CreateUserId As TaskCreateUserId
  922. From Pm_TaskRelevanceUser tau
  923. Left Join Sys_Users u On tau.UserId = u.Id
  924. Where tau.IsDel = 0");
  925. var taskerData = _taskAllocationRep._sqlSugar.SqlQueryable<TaskerDetailsView>(taskerSql).Where(it => taskIds.Contains(it.TAId)).ToList();
  926. foreach (var item in _view)
  927. {
  928. item.TaskerDetails = taskerData.Where(it => it.TAId == item.Id).ToList();
  929. ////处理任务总状态 And 任务人状态
  930. //var taskerStatusData = taskerData.Where(it => it.TAId == item.Id && it.TaskCreateUserId != dto.UserId && it.UserId == dto.UserId).FirstOrDefault();
  931. //if (taskerStatusData != null)
  932. //{
  933. // item.Status = taskerStatusData.TaskStatus;
  934. //}
  935. }
  936. return Ok(JsonView(true, "查询成功!", _view, total));
  937. }
  938. catch (Exception ex)
  939. {
  940. return Ok(JsonView(false, ex.Message));
  941. }
  942. }
  943. /// <summary>
  944. /// 任务分配
  945. /// 详情
  946. /// </summary>
  947. /// <returns></returns>
  948. [HttpPost]
  949. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  950. public async Task<IActionResult> PostTaskAllocationDetails(TaskAllocationDetailsDto dto)
  951. {
  952. try
  953. {
  954. #region 参数验证
  955. if (dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
  956. if (dto.PageId < 1) dto.PageId = 172; //任务指派Id
  957. PageFunAuthViewBase pageFunAuthView = new PageFunAuthViewBase();
  958. #region 页面操作权限验证
  959. pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(dto.UserId, dto.PageId);
  960. if (pageFunAuthView.CheckAuth == 0) return Ok(JsonView(false, "您没有查看权限!"));
  961. #endregion
  962. #endregion
  963. var _view = await _taskAllocationRep._Details(dto.PortType, dto.Id);
  964. if (_view.Code == 0)
  965. {
  966. return Ok(JsonView(true, "查询成功!", _view.Data));
  967. }
  968. return Ok(JsonView(false, _view.Msg));
  969. }
  970. catch (Exception ex)
  971. {
  972. return Ok(JsonView(false, ex.Message));
  973. }
  974. }
  975. /// <summary>
  976. /// 任务分配
  977. /// Add Or Edit
  978. /// </summary>
  979. /// <returns></returns>
  980. [HttpPost]
  981. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  982. public async Task<IActionResult> PostTaskAllocationAddOrEdit(TaskAllocationAddOrEditDto dto)
  983. {
  984. try
  985. {
  986. #region 参数验证
  987. if (dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
  988. if (dto.PageId < 1) dto.PageId = 172; //任务指派Id
  989. PageFunAuthViewBase pageFunAuthView = new PageFunAuthViewBase();
  990. #region 页面操作权限验证
  991. pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(dto.UserId, dto.PageId);
  992. if (dto.Id == 0)
  993. {
  994. if (pageFunAuthView.AddAuth == 0) return Ok(JsonView(false, "您没有添加权限!"));
  995. }
  996. else if (dto.Id > 0)
  997. {
  998. if (pageFunAuthView.EditAuth == 0) return Ok(JsonView(false, "您没有编辑权限!"));
  999. }
  1000. #endregion
  1001. #endregion
  1002. var _view = await _taskAllocationRep._AddOrEdit(dto);
  1003. if (_view.Code == 0)
  1004. {
  1005. if (dto.Id == 0) //添加提示任务单创建
  1006. {
  1007. string title = $"[{dto.TaskName}] 任务新建成功!";
  1008. string content = $"[{dto.TaskName}] 任务新建成功,请前往任务页面查看详情!";
  1009. await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title, content, dto.UserIds);
  1010. }
  1011. return Ok(JsonView(true, "操作成功!"));
  1012. }
  1013. return Ok(JsonView(false, _view.Msg));
  1014. }
  1015. catch (Exception ex)
  1016. {
  1017. return Ok(JsonView(false, ex.Message));
  1018. }
  1019. }
  1020. /// <summary>
  1021. /// 任务分配
  1022. /// 状态任务归属人详情
  1023. /// </summary>
  1024. /// <returns></returns>
  1025. [HttpPost]
  1026. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  1027. public async Task<IActionResult> PostTaskAllocationTaskerDetails(TaskerDetailsDto dto)
  1028. {
  1029. try
  1030. {
  1031. var _view = await _taskAllocationRep._TaskerDetails(dto.Id);
  1032. if (_view.Code == 0)
  1033. {
  1034. return Ok(JsonView(true, "操作成功!", _view.Data));
  1035. }
  1036. return Ok(JsonView(false, _view.Msg));
  1037. }
  1038. catch (Exception ex)
  1039. {
  1040. return Ok(JsonView(false, ex.Message));
  1041. }
  1042. }
  1043. /// <summary>
  1044. /// 任务分配
  1045. /// 状态任务归属人设置开始状态
  1046. /// </summary>
  1047. /// <returns></returns>
  1048. [HttpPost]
  1049. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  1050. public async Task<IActionResult> PostTaskAllocationSetStartStatus(TaskerStatusDto dto)
  1051. {
  1052. try
  1053. {
  1054. var _view = await _taskAllocationRep._TaskerSetStartStatus(dto.UserId, dto.Id);
  1055. if (_view.Code == 0)
  1056. {
  1057. //发送消息
  1058. var taskData = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskAllocation>().Where(it => it.Id == dto.Id).First();
  1059. if (taskData != null)
  1060. {
  1061. var taskUserIds = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskRelevanceUser>().Where(it => it.TAId == dto.Id).Select(it => it.UserId).ToList();
  1062. if (taskUserIds.Count > 0)
  1063. {
  1064. taskUserIds.Remove(dto.UserId);
  1065. }
  1066. var UserName = _taskAllocationRep._sqlSugar.Queryable<Sys_Users>().Where(it => it.Id == dto.UserId).Select(it => it.CnName).First();
  1067. string title_createUser = $"[{taskData.TaskName}] 进度更新!";
  1068. string conten_createUser = $"[{UserName}] 已开始任务,请注意该工作人员任务进度!";
  1069. await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title_createUser, conten_createUser, new List<int>() { taskData.CreateUserId }); //创建人发送消息
  1070. string title = $"[{taskData.TaskName}] 进度更新!";
  1071. string content = $"[{UserName}] 已开始任务.若需查看,请前往任务页面查看详情!";
  1072. await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title, content, taskUserIds); //其他人发送消息
  1073. string content1 = $"任务已开始,请在规定时间完成!若需查看,请前往任务页面查看详情!";
  1074. await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title, content1, new List<int>() { dto.UserId }); //设置任务人 发送消息
  1075. }
  1076. return Ok(JsonView(true, "操作成功!"));
  1077. }
  1078. return Ok(JsonView(false, _view.Msg));
  1079. }
  1080. catch (Exception ex)
  1081. {
  1082. return Ok(JsonView(false, ex.Message));
  1083. }
  1084. }
  1085. /// <summary>
  1086. /// 任务分配
  1087. /// 状态 任务归属人 设置完成状态
  1088. /// </summary>
  1089. /// <returns></returns>
  1090. [HttpPost]
  1091. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  1092. public async Task<IActionResult> PostTaskAllocationSetOverStatus(TaskerStatusDto dto)
  1093. {
  1094. try
  1095. {
  1096. var _view = await _taskAllocationRep._TaskerSetOverStatus(dto.UserId, dto.Id);
  1097. if (_view.Code == 0)
  1098. {
  1099. //发送消息
  1100. var taskData = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskAllocation>().Where(it => it.Id == dto.Id).First();
  1101. if (taskData != null)
  1102. {
  1103. var taskUserIds = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskRelevanceUser>().Where(it => it.TAId == dto.Id).Select(it => it.UserId).ToList();
  1104. if (taskUserIds.Count > 0)
  1105. {
  1106. taskUserIds.Remove(dto.UserId);
  1107. }
  1108. var UserName = _taskAllocationRep._sqlSugar.Queryable<Sys_Users>().Where(it => it.Id == dto.UserId).Select(it => it.CnName).First();
  1109. string title_createUser = $"[{taskData.TaskName}] 进度更新!";
  1110. string conten_createUser = $"[{UserName}] 已完成任务,请前往任务页面进行审核操作!";
  1111. await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title_createUser, conten_createUser, new List<int>() { taskData.CreateUserId }); //创建人发送消息
  1112. string title = $"[{taskData.TaskName}] 进度更新!";
  1113. string content = $"[{UserName}] 已完成任务,请注意在规定时间内完成任务.若需查看,请前往任务页面查看详情!";
  1114. await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title, content, taskUserIds); //其他人发送消息
  1115. string content1 = $"任务已完成,等待任务发布人审核!若需查看,请前往任务页面查看详情!";
  1116. await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title, content1, new List<int>() { dto.UserId }); //设置任务人 发送消息
  1117. }
  1118. return Ok(JsonView(true, "操作成功!"));
  1119. }
  1120. return Ok(JsonView(false, _view.Msg));
  1121. }
  1122. catch (Exception ex)
  1123. {
  1124. return Ok(JsonView(false, ex.Message));
  1125. }
  1126. }
  1127. /// <summary>
  1128. /// 任务分配
  1129. /// 状态 任务归属人 设置知晓状态
  1130. /// </summary>
  1131. /// <returns></returns>
  1132. [HttpPost]
  1133. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  1134. public async Task<IActionResult> PostTaskAllocationSetHaveStatus(TaskAllocationStatusDto dto)
  1135. {
  1136. try
  1137. {
  1138. var _view = await _taskAllocationRep._TaskSetHaveStatus(dto.SubId);
  1139. if (_view.Code == 0)
  1140. {
  1141. //发送消息
  1142. var taskUserData = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskRelevanceUser>().Where(it => it.Id == dto.SubId).First();
  1143. if (taskUserData != null)
  1144. {
  1145. var taskData = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskAllocation>().Where(it => it.Id == taskUserData.TAId).First();
  1146. if (taskData != null)
  1147. {
  1148. var UserName = _taskAllocationRep._sqlSugar.Queryable<Sys_Users>().Where(it => it.Id == taskData.CreateUserId).Select(it => it.CnName).First();
  1149. string title = $"[{taskData.TaskName}] 进度更新!";
  1150. string conten_createUser = $"[{UserName}] 已知晓任务.若需查看,请前往任务页面查看详情!";
  1151. await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title, conten_createUser, new List<int>() { taskData.CreateUserId }); //创建人发送消息
  1152. string content = $"请注意任务完成时间!若需查看,请前往任务页面查看详情!";
  1153. await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title, content, new List<int>() { taskUserData.UserId }); //设置任务人 发送消息
  1154. }
  1155. }
  1156. return Ok(JsonView(true, "操作成功!"));
  1157. }
  1158. return Ok(JsonView(false, _view.Msg));
  1159. }
  1160. catch (Exception ex)
  1161. {
  1162. return Ok(JsonView(false, ex.Message));
  1163. }
  1164. }
  1165. /// <summary>
  1166. /// 任务分配
  1167. /// 任务发布者 单人设置审批状态
  1168. /// </summary>
  1169. /// <returns></returns>
  1170. [HttpPost]
  1171. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  1172. public async Task<IActionResult> PostTaskAllocationSetAuditStatus(TaskAllocationStatusDto dto)
  1173. {
  1174. try
  1175. {
  1176. var _view = await _taskAllocationRep._TaskSetAuditStatus(dto.SubId);
  1177. if (_view.Code == 0)
  1178. {
  1179. //发送消息
  1180. var taskUserData = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskRelevanceUser>().Where(it => it.Id == dto.SubId).First();
  1181. if (taskUserData != null)
  1182. {
  1183. var taskData = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskAllocation>().Where(it => it.Id == taskUserData.TAId).First();
  1184. if (taskData != null)
  1185. {
  1186. string title = $"[{taskData.TaskName}] 进度更新!";
  1187. string content = $"任务已完成!若需查看,请前往任务页面查看详情!";
  1188. await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title, content, new List<int>() { taskUserData.UserId }); //设置任务人 发送消息
  1189. }
  1190. }
  1191. return Ok(JsonView(true, "操作成功!"));
  1192. }
  1193. return Ok(JsonView(false, _view.Msg));
  1194. }
  1195. catch (Exception ex)
  1196. {
  1197. return Ok(JsonView(false, ex.Message));
  1198. }
  1199. }
  1200. /// <summary>
  1201. /// 任务分配
  1202. /// 任务发布者 单人设置未完成状态
  1203. /// </summary>
  1204. /// <returns></returns>
  1205. [HttpPost]
  1206. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  1207. public async Task<IActionResult> PostTaskAllocationSetUnFinishedStatus(TaskAllocationSetUnFinishedStatusDto dto)
  1208. {
  1209. try
  1210. {
  1211. var _view = await _taskAllocationRep._TaskSetUnFinishedStatus(dto.SubId, dto.Cause);
  1212. if (_view.Code == 0)
  1213. {
  1214. //发送消息
  1215. var taskUserData = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskRelevanceUser>().Where(it => it.Id == dto.SubId).First();
  1216. if (taskUserData != null)
  1217. {
  1218. var taskData = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskAllocation>().Where(it => it.Id == taskUserData.TAId).First();
  1219. if (taskData != null)
  1220. {
  1221. string title = $"[{taskData.TaskName}] 进度更新!";
  1222. string content = $"任务未完成!若需查看,请前往任务页面查看详情!";
  1223. await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title, content, new List<int>() { taskUserData.UserId }); //设置任务人 发送消息
  1224. }
  1225. }
  1226. return Ok(JsonView(true, "操作成功!"));
  1227. }
  1228. return Ok(JsonView(false, _view.Msg));
  1229. }
  1230. catch (Exception ex)
  1231. {
  1232. return Ok(JsonView(false, ex.Message));
  1233. }
  1234. }
  1235. ///// <summary>
  1236. ///// 任务分配
  1237. ///// 确认任务是否可操作完成
  1238. ///// </summary>
  1239. ///// <returns></returns>
  1240. //[HttpPost]
  1241. //[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  1242. //public async Task<IActionResult> PostTaskAllocationIsConfirmCompletion(TaskAllocationScoreDto dto)
  1243. //{
  1244. // try
  1245. // {
  1246. // #region 参数验证
  1247. // if (dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
  1248. // if (dto.PageId < 1) dto.PageId = 172; //任务指派Id
  1249. // PageFunAuthViewBase pageFunAuthView = new PageFunAuthViewBase();
  1250. // #region 页面操作权限验证
  1251. // pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(dto.UserId, dto.PageId);
  1252. // if (pageFunAuthView.EditAuth == 0) return Ok(JsonView(false, "您没有编辑权限!"));
  1253. // #endregion
  1254. // #endregion
  1255. // var _view = await _taskAllocationRep._TaskConfirmCompletion(dto.PortType, dto.Id);
  1256. // if (_view.Code == 0)
  1257. // {
  1258. // return Ok(JsonView(true, "操作成功!"));
  1259. // }
  1260. // return Ok(JsonView(false, _view.Msg));
  1261. // }
  1262. // catch (Exception ex)
  1263. // {
  1264. // return Ok(JsonView(false, ex.Message));
  1265. // }
  1266. //}
  1267. ///// <summary>
  1268. ///// 任务分配
  1269. ///// 任务确认完成
  1270. ///// </summary>
  1271. ///// <returns></returns>
  1272. //[HttpPost]
  1273. //[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  1274. //public async Task<IActionResult> PostTaskAllocationConfirmCompletion(TaskAllocationConfirmCompletionDto dto)
  1275. //{
  1276. // try
  1277. // {
  1278. // #region 参数验证
  1279. // if (dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
  1280. // if (dto.PageId < 1) dto.PageId = 172; //任务指派Id
  1281. // PageFunAuthViewBase pageFunAuthView = new PageFunAuthViewBase();
  1282. // #region 页面操作权限验证
  1283. // pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(dto.UserId, dto.PageId);
  1284. // if (pageFunAuthView.EditAuth == 0) return Ok(JsonView(false, "您没有编辑权限!"));
  1285. // #endregion
  1286. // #endregion
  1287. // var _view = await _taskAllocationRep._TaskConfirmCompletion(dto.PortType,dto.Id);
  1288. // if (_view.Code == 0)
  1289. // {
  1290. // return Ok(JsonView(true, "操作成功!"));
  1291. // }
  1292. // return Ok(JsonView(false, _view.Msg));
  1293. // }
  1294. // catch (Exception ex)
  1295. // {
  1296. // return Ok(JsonView(false, ex.Message));
  1297. // }
  1298. //}
  1299. /// <summary>
  1300. /// 任务分配
  1301. /// 任务发布者 任务评分
  1302. /// </summary>
  1303. /// <returns></returns>
  1304. [HttpPost]
  1305. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  1306. public async Task<IActionResult> PostTaskAllocationScore(TaskAllocationScoreDto dto)
  1307. {
  1308. try
  1309. {
  1310. #region 参数验证
  1311. if (dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
  1312. if (dto.PageId < 1) dto.PageId = 172; //任务指派Id
  1313. PageFunAuthViewBase pageFunAuthView = new PageFunAuthViewBase();
  1314. #region 页面操作权限验证
  1315. pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(dto.UserId, dto.PageId);
  1316. if (pageFunAuthView.EditAuth == 0) return Ok(JsonView(false, "您没有编辑权限!"));
  1317. #endregion
  1318. #endregion
  1319. var _view = await _taskAllocationRep._TaskScore(dto);
  1320. if (_view.Code == 0)
  1321. {
  1322. //发送消息
  1323. var taskUserData = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskRelevanceUser>().Where(it => it.Id == dto.SubId).First();
  1324. if (taskUserData != null)
  1325. {
  1326. var taskData = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskAllocation>().Where(it => it.Id == taskUserData.TAId).First();
  1327. if (taskData != null)
  1328. {
  1329. string title = $"[{taskData.TaskName}] 进度更新!";
  1330. string content = $"任务评分已完成!若需查看,请前往任务页面查看详情!";
  1331. await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title, content, new List<int>() { taskUserData.UserId }); //设置任务人 发送消息
  1332. }
  1333. }
  1334. return Ok(JsonView(true, "操作成功!"));
  1335. }
  1336. return Ok(JsonView(false, _view.Msg));
  1337. }
  1338. catch (Exception ex)
  1339. {
  1340. return Ok(JsonView(false, ex.Message));
  1341. }
  1342. }
  1343. /// <summary>
  1344. /// 任务分配
  1345. /// 任务发布者 任务终止
  1346. /// </summary>
  1347. /// <returns></returns>
  1348. [HttpPost]
  1349. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  1350. public async Task<IActionResult> PostTaskAllocationTermination(TaskAllocationConfirmCompletionDto dto)
  1351. {
  1352. try
  1353. {
  1354. #region 参数验证
  1355. if (dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
  1356. if (dto.PageId < 1) dto.PageId = 172; //任务指派Id
  1357. PageFunAuthViewBase pageFunAuthView = new PageFunAuthViewBase();
  1358. #region 页面操作权限验证
  1359. pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(dto.UserId, dto.PageId);
  1360. if (pageFunAuthView.EditAuth == 0) return Ok(JsonView(false, "您没有编辑权限!"));
  1361. #endregion
  1362. #endregion
  1363. var _view = await _taskAllocationRep._TaskTermination(dto.Id);
  1364. if (_view.Code == 0)
  1365. {
  1366. //发送消息
  1367. var taskData = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskAllocation>().Where(it => it.Id == dto.Id).First();
  1368. if (taskData != null)
  1369. {
  1370. var taskUserIds = _taskAllocationRep._sqlSugar.Queryable<Pm_TaskRelevanceUser>().Where(it => it.Id == dto.Id).Select(it => it.UserId).ToList();
  1371. taskUserIds.Add(taskData.CreateUserId);
  1372. string title = $"[{taskData.TaskName}] 进度更新!";
  1373. string content = $"任务已终止!若需查看,请前往任务页面查看详情!";
  1374. await GeneralMethod.MessageIssueAndNotification(MessageTypeEnum.TaskProgressUpdate, title, content, taskUserIds); //设置任务人 发送消息
  1375. }
  1376. return Ok(JsonView(true, "操作成功!"));
  1377. }
  1378. return Ok(JsonView(false, _view.Msg));
  1379. }
  1380. catch (Exception ex)
  1381. {
  1382. return Ok(JsonView(false, ex.Message));
  1383. }
  1384. }
  1385. /// <summary>
  1386. /// 任务分配
  1387. /// 任务发布者 任务删除
  1388. /// </summary>
  1389. /// <returns></returns>
  1390. [HttpPost]
  1391. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  1392. public async Task<IActionResult> PostTaskAllocationDel(TaskAllocationConfirmCompletionDto dto)
  1393. {
  1394. try
  1395. {
  1396. #region 参数验证
  1397. if (dto.UserId < 1) return Ok(JsonView(false, "员工Id为空"));
  1398. if (dto.PageId < 1) dto.PageId = 172; //任务指派Id
  1399. PageFunAuthViewBase pageFunAuthView = new PageFunAuthViewBase();
  1400. #region 页面操作权限验证
  1401. pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(dto.UserId, dto.PageId);
  1402. if (pageFunAuthView.DeleteAuth == 0) return Ok(JsonView(false, "您没有删除权限!"));
  1403. #endregion
  1404. #endregion
  1405. var _view = await _taskAllocationRep._TaskDel(dto.Id);
  1406. if (_view.Code == 0)
  1407. {
  1408. return Ok(JsonView(true, "操作成功!"));
  1409. }
  1410. return Ok(JsonView(false, _view.Msg));
  1411. }
  1412. catch (Exception ex)
  1413. {
  1414. return Ok(JsonView(false, ex.Message));
  1415. }
  1416. }
  1417. #endregion
  1418. #region 团组状态通知
  1419. /// <summary>
  1420. /// 测试
  1421. /// </summary>
  1422. /// <param name="dto"></param>
  1423. /// <returns></returns>
  1424. [HttpPost]
  1425. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  1426. public async Task<IActionResult> Test_QIYEWX(PostTourClientListDownloadFile dto)
  1427. {
  1428. //List<string> templist = new List<string>() { 234.ToString() };
  1429. //await AppNoticeLibrary.SendUserMsg_GroupStatus_AuditFee(14090, templist, QiyeWeChatEnum.TestChat);
  1430. //await AppNoticeLibrary.SendUserMsg_GroupShare_ToJob(dto.DiId); ;
  1431. //DeleReminderMessage.PostMessageByWebhook();
  1432. //GroupStatus_UserSimplelistView list = await _qiYeWeChatApiService.GroupStatus_GetUserList();
  1433. //创建群聊
  1434. //List<string> userList1 = new List<string>() { "Feint", "amy.zhu@pan-american-intl.com", "judy.zeng@pan-american-intl.com", "FuHongJin" };
  1435. //List<string> userList2 = new List<string>() { "Feint", "ZhaoYaQi", "LiaoWenYa" };
  1436. //List<string> userList3 = new List<string>() { "Feint", "amy.zhu@pan-american-intl.com", "judy.zeng@pan-american-intl.com", "FuHongJin", "ZhaoYaQi", "LiaoWenYa" };
  1437. //GroupStatus_CreateChatView rst1 = await _qiYeWeChatApiService.GroupStatus_CreateChat("团组通知", "Feint", userList1, "CaiWuChat01");
  1438. //GroupStatus_CreateChatView rst2 = await _qiYeWeChatApiService.GroupStatus_CreateChat("OA通知-国交部", "Feint", userList2, "GuoJiaoLeader01");
  1439. //GroupStatus_CreateChatView rst3 = await _qiYeWeChatApiService.GroupStatus_CreateChat("OA通知-团组(公司客户)", "Feint", userList3, "CompanyCRMChat01");
  1440. //推送消息(模板)
  1441. //List<string> userList = new List<string>() { "Feint", "huaju.liu", "johnny.yang@pan-american-intl.com" };
  1442. //List<string> userList = new List<string>() { "Feint", "johnny.yang@pan-american-intl.com" };
  1443. //GroupStatus_CreateChatView rst1 = await _qiYeWeChatApiService.GroupStatus_CreateChat("团组费用提示", "Feint", userList, "GuoJiaoChat01");
  1444. //团组出发
  1445. //AppNoticeLibrary.SendUserMsg_GroupStatus_Create(2358, userList);
  1446. //费用审核
  1447. //AppNoticeLibrary.SendChatMsg_GroupStatus_ApplyFee(dto.DiId, QiyeWeChatEnum.TestChat);
  1448. //费用审核结果通知(通过情况下发送财务群)
  1449. //List<string> userList = new List<string>() { "234" };
  1450. //AppNoticeLibrary.SendUserMsg_GroupStatus_AuditFee(dto.DiId, userList, QiyeWeChatEnum.CaiWuChat02);
  1451. //4、财务付款时:(1)对应版块人员【单独发,状态为已付款才发】
  1452. //AppNoticeLibrary.SendUserMsg_GroupStatus_PayResult(dto.DiId, userList);
  1453. //团组提醒财务群
  1454. //DateTime dtNow = DateTime.Now;
  1455. //List<Grp_DelegationInfo> listSource = _usersRep.Query<Grp_DelegationInfo>(s => s.IsDel == 0 && s.VisitStartDate >= dtNow).Take(3).ToList();
  1456. //List<Grp_DelegationInfo> listAdd7day = _usersRep.Query<Grp_DelegationInfo>(s => s.IsDel == 0 && s.VisitStartDate >= dtNow).Take(3).ToList();
  1457. //List<Grp_DelegationInfo> listAdd3day = new List<Grp_DelegationInfo>() { };
  1458. //AppNoticeLibrary.SendChatMsg_GroupRemindersToCaiwu(listAdd7day, listAdd3day, QiyeWeChatEnum.TestChat);
  1459. //日付申请提醒财务群
  1460. //AppNoticeLibrary.DailyPayReminders_Create_ToCaiwuChat(dto.DiId, QiyeWeChatEnum.CaiWuChat02);
  1461. //日付申请结果推送用户、成功通知财务群
  1462. //AppNoticeLibrary.DailyPayReminder_Audit_ToUser(dto.DiId, userList, QiyeWeChatEnum.TestChat);
  1463. //AppNoticeLibrary.DailyPayReminder_Pay_ToUser(dto.DiId, userList);
  1464. string q = "";
  1465. DeleReminderMessage.PostMessageByWebhook_CRMStatistics();
  1466. return Ok(JsonView(true, "操作成功!"));
  1467. }
  1468. #endregion
  1469. #region 物资进销存
  1470. /// <summary>
  1471. /// 物资进销存
  1472. /// 基础数据类型
  1473. /// </summary>
  1474. /// <returns></returns>
  1475. [HttpGet]
  1476. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  1477. public async Task<IActionResult> GoodsInitDataSource()
  1478. {
  1479. return Ok(await _goodsRep.InitDataSource());
  1480. }
  1481. /// <summary>
  1482. /// 物资进销存
  1483. /// 物品 列表
  1484. /// </summary>
  1485. /// <returns></returns>
  1486. [HttpPost]
  1487. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  1488. public async Task<IActionResult> GoodsList(GoodsListDto dto)
  1489. {
  1490. if (dto.PortType < 1 || dto.PortType > 3) return Ok(JsonView(false, MsgTips.Port));
  1491. if (dto.PageIndex < 1 || dto.PageSize < 1) return Ok(JsonView(false, MsgTips.PageIndex));
  1492. return Ok(await _goodsRep.GoodsList(dto));
  1493. }
  1494. /// <summary>
  1495. /// 物资进销存
  1496. /// 物品 详情
  1497. /// </summary>
  1498. /// <returns></returns>
  1499. [HttpGet()]
  1500. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  1501. public async Task<IActionResult> GoodsInfo(int portType, int id)
  1502. {
  1503. if (portType < 1 || portType > 3) return Ok(JsonView(false, MsgTips.Port));
  1504. if (id < 1) return Ok(JsonView(false, MsgTips.Id));
  1505. return Ok(await _goodsRep.GoodsInfo(portType, id));
  1506. }
  1507. /// <summary>
  1508. /// 物资进销存
  1509. /// 物品 OP(Add OR Edit)
  1510. /// </summary>
  1511. /// <returns></returns>
  1512. [HttpPost]
  1513. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  1514. public async Task<IActionResult> GoodsOP(GoodsOpDto dto)
  1515. {
  1516. var currUserInfo = JwtHelper.SerializeJwt(HttpContext.Request.Headers.Authorization);
  1517. if (currUserInfo == null) return Ok(JsonView(false, "请传入token!"));
  1518. var validator = new GoodsOPDTOValidator();
  1519. var validatorRes = await validator.ValidateAsync(dto);
  1520. if (!validatorRes.IsValid)
  1521. {
  1522. var sb = new StringBuilder();
  1523. foreach (var error in validatorRes.Errors) sb.AppendLine(error.ErrorMessage);
  1524. return Ok(JsonView(false, sb.ToString()));
  1525. }
  1526. return Ok(await _goodsRep.GoodsOp(dto, currUserInfo.UserId));
  1527. }
  1528. /// <summary>
  1529. /// 物资进销存
  1530. /// 物品 Del
  1531. /// </summary>
  1532. /// <returns></returns>
  1533. [HttpDelete("{id}")]
  1534. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  1535. public async Task<IActionResult> GoodsDel(int id)
  1536. {
  1537. if (id < 1) return Ok(JsonView(false, MsgTips.Id));
  1538. var currUserInfo = JwtHelper.SerializeJwt(HttpContext.Request.Headers.Authorization);
  1539. if (currUserInfo == null) return Ok(JsonView(false, "请传入token!"));
  1540. return Ok(await _goodsRep.GoodsDel(id, currUserInfo.UserId));
  1541. }
  1542. /// <summary>
  1543. /// 物资进销存
  1544. /// 入库 列表
  1545. /// </summary>
  1546. /// <returns></returns>
  1547. [HttpPost]
  1548. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  1549. public async Task<IActionResult> GoodsStorageList(GoodsStorageListDto dto)
  1550. {
  1551. if (dto.PortType < 1 || dto.PortType > 3) return Ok(JsonView(false, MsgTips.Port));
  1552. if (dto.PageIndex < 1 || dto.PageSize < 1) return Ok(JsonView(false, MsgTips.PageIndex));
  1553. return Ok(await _goodsRep.GoodsStorageList(dto));
  1554. }
  1555. /// <summary>
  1556. /// 物资进销存
  1557. /// 入库 详情
  1558. /// </summary>
  1559. /// <returns></returns>
  1560. [HttpGet("{id}")]
  1561. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  1562. public async Task<IActionResult> GoodsStorageInfo([FromQuery] int portType, int id)
  1563. {
  1564. if (portType < 1 || portType > 3) return Ok(JsonView(false, MsgTips.Port));
  1565. if (id < 1) return Ok(JsonView(false, MsgTips.Id));
  1566. return Ok(await _goodsRep.GoodsStorageInfo(portType, id));
  1567. }
  1568. /// <summary>
  1569. /// 物资进销存
  1570. /// 入库 OP(Add OR Edit)
  1571. /// </summary>
  1572. /// <returns></returns>
  1573. [HttpPost]
  1574. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  1575. public async Task<IActionResult> GoodsStorageOp(GoodsStorageOpDto dto)
  1576. {
  1577. var currUserInfo = JwtHelper.SerializeJwt(HttpContext.Request.Headers.Authorization);
  1578. if (currUserInfo == null) return Ok(JsonView(false, "请传入token!"));
  1579. var validator = new GoodsStorageOpDtoValidator();
  1580. var validatorRes = await validator.ValidateAsync(dto);
  1581. if (!validatorRes.IsValid)
  1582. {
  1583. var sb = new StringBuilder();
  1584. foreach (var error in validatorRes.Errors) sb.AppendLine(error.ErrorMessage);
  1585. return Ok(JsonView(false, sb.ToString()));
  1586. }
  1587. return Ok(await _goodsRep.GoodsStorageOp(dto, currUserInfo.UserId));
  1588. }
  1589. /// <summary>
  1590. /// 物资进销存
  1591. /// 入库 Del
  1592. /// </summary>
  1593. /// <returns></returns>
  1594. [HttpDelete("{id}")]
  1595. //[Authorize]
  1596. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  1597. public async Task<IActionResult> GoodsStorageDel(int id)
  1598. {
  1599. var currUserInfo = JwtHelper.SerializeJwt(HttpContext.Request.Headers.Authorization);
  1600. if (currUserInfo == null) return Ok(JsonView(false, "请传入token!"));
  1601. if (id < 1) return Ok(JsonView(false, MsgTips.Id));
  1602. return Ok(await _goodsRep.GoodsStorageDel(id, currUserInfo.UserId));
  1603. }
  1604. /// <summary>
  1605. /// 物资进销存
  1606. /// 领用 List
  1607. /// </summary>
  1608. /// <returns></returns>
  1609. [HttpPost]
  1610. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  1611. public async Task<IActionResult> GoodsReceiveList(GoodsReceiveListDTO dto)
  1612. {
  1613. //var currUserInfo = JwtHelper.SerializeJwt(HttpContext.Request.Headers.Authorization);
  1614. //if (currUserInfo == null) return Ok(JsonView(false, "请传入token!"));
  1615. if (dto.PortType < 1 || dto.PortType > 3) return Ok(JsonView(false, MsgTips.Port));
  1616. if (dto.PageIndex < 1 || dto.PageSize < 1) return Ok(JsonView(false, MsgTips.PageIndex));
  1617. return Ok(await _goodsRep.GoodsReceiveList(dto));
  1618. }
  1619. /// <summary>
  1620. /// 物资进销存
  1621. /// 领用详情
  1622. /// </summary>
  1623. /// <returns></returns>
  1624. [HttpGet("{id}")]
  1625. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  1626. public async Task<IActionResult> GoodsReceiveInfo([FromQuery] int portType, int id)
  1627. {
  1628. if (portType < 1 || portType > 3) return Ok(JsonView(false, MsgTips.Port));
  1629. if (id < 1) return Ok(JsonView(false, MsgTips.Id));
  1630. return Ok(await _goodsRep.GoodsReceiveInfo(portType, id));
  1631. }
  1632. /// <summary>
  1633. /// 物资进销存
  1634. /// 领用 OP
  1635. /// </summary>
  1636. /// <returns></returns>
  1637. [HttpPost]
  1638. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  1639. public async Task<IActionResult> GoodsReceiveOP(GoodsReceiveOpDto dto)
  1640. {
  1641. var currUserInfo = JwtHelper.SerializeJwt(HttpContext.Request.Headers.Authorization);
  1642. if (currUserInfo == null) return Ok(JsonView(false, "请传入token!"));
  1643. var validator = new GoodsReceiveOpDtoValidator();
  1644. var validatorRes = await validator.ValidateAsync(dto);
  1645. if (!validatorRes.IsValid)
  1646. {
  1647. var sb = new StringBuilder();
  1648. foreach (var error in validatorRes.Errors) sb.AppendLine(error.ErrorMessage);
  1649. return Ok(JsonView(false, sb.ToString()));
  1650. }
  1651. return Ok(await _goodsRep.GoodsReceiveOp(dto, currUserInfo.UserId));
  1652. }
  1653. /// <summary>
  1654. /// 物资进销存
  1655. /// 领用 审核
  1656. /// </summary>
  1657. /// <param name="dto"></param>
  1658. /// <returns></returns>
  1659. [HttpPost]
  1660. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  1661. public async Task<IActionResult> GoodsReceiveAudit(GoodsReceiveAuditDTO dto)
  1662. {
  1663. var currUserInfo = JwtHelper.SerializeJwt(HttpContext.Request.Headers.Authorization);
  1664. if (currUserInfo == null) return Ok(JsonView(false, "请传入token!"));
  1665. var validator = new GoodsReceiveAuditDTOValidator();
  1666. var validatorRes = await validator.ValidateAsync(dto);
  1667. if (!validatorRes.IsValid)
  1668. {
  1669. var sb = new StringBuilder();
  1670. foreach (var error in validatorRes.Errors) sb.AppendLine(error.ErrorMessage);
  1671. return Ok(JsonView(false, sb.ToString()));
  1672. }
  1673. int[] idArray = dto.Label
  1674. .Split(',')
  1675. .Select(x =>
  1676. {
  1677. if (int.TryParse(x, out var id)) return id;
  1678. return id;
  1679. })
  1680. .ToArray();
  1681. return Ok(await _goodsRep.GoodsReceiveAudit(idArray, currUserInfo.UserId, dto.AuditEnum));
  1682. }
  1683. /// <summary>
  1684. /// 物资进销存
  1685. /// 领用 Del
  1686. /// </summary>
  1687. /// <returns></returns>
  1688. [HttpDelete("{id}")]
  1689. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  1690. public async Task<IActionResult> GoodsReceiveDel(int id)
  1691. {
  1692. var currUserInfo = JwtHelper.SerializeJwt(HttpContext.Request.Headers.Authorization);
  1693. if (currUserInfo == null) return Ok(JsonView(false, "请传入token!"));
  1694. if (id < 1) return Ok(JsonView(false, MsgTips.Id));
  1695. return Ok(await _goodsRep.GoodsReceiveDel(id, currUserInfo.UserId));
  1696. }
  1697. #endregion
  1698. #region 员工绩效
  1699. /// <summary>
  1700. /// 员工绩效组成结构获取
  1701. /// </summary>
  1702. /// <param name="userid"></param>
  1703. /// <param name="date"></param>
  1704. /// <returns></returns>
  1705. [HttpGet]
  1706. public IActionResult GetPerformanceList(int userid,string date)
  1707. {
  1708. var jw = JsonView(false);
  1709. if (!DateTime.TryParse(date,out DateTime date_Dt))
  1710. {
  1711. jw.Msg = "日期格式有误!";
  1712. return Ok(jw);
  1713. }
  1714. string sql_CTE = $@"-- 定义递归查询的CTE
  1715. WITH PerAssessmentSettingsCTE AS (
  1716. -- 选择指定ID的记录作为起点
  1717. SELECT
  1718. pac.Id,
  1719. pac.Name,
  1720. pac.AssessmentProportion,
  1721. pac.AssessmentStandard,
  1722. pac.ParentId,
  1723. 1 AS Depth
  1724. FROM
  1725. Per_AssessmentSetting pac
  1726. INNER JOIN
  1727. Per_AssessmentContentSetting pacs
  1728. ON
  1729. pac.id = pacs.assessmentSettingid AND pacs.isdel = 0
  1730. WHERE
  1731. pacs.userid = {userid}
  1732. AND
  1733. pac.isdel = 0
  1734. UNION ALL
  1735. -- 递归部分,选择所有子级记录
  1736. SELECT
  1737. ps.Id,
  1738. ps.Name,
  1739. ps.AssessmentProportion,
  1740. ps.AssessmentStandard,
  1741. ps.ParentId,
  1742. CAST(caste.Depth as int) + 1
  1743. FROM
  1744. Per_AssessmentSetting ps
  1745. INNER JOIN PerAssessmentSettingsCTE caste ON ps.Id = caste.ParentId)
  1746. -- 从CTE中选择最终结果
  1747. SELECT * FROM PerAssessmentSettingsCTE
  1748. OPTION (MAXRECURSION 0); -- 允许无限递归 ";
  1749. var result_CTE = _sqlSugar.Ado.SqlQuery<Per_AssessmentSetting>(sql_CTE);
  1750. var ids = result_CTE.Select(x => x.Id);
  1751. var List = _sqlSugar.Queryable<Per_AssessmentSetting>()
  1752. .LeftJoin<Per_AssessmentContentSetting>((a, b) => a.Id == b.AssessmentSettingId && b.IsDel == 0 && b.UserId == userid)
  1753. .LeftJoin<Per_AssessmentScore>((a, b,c) => b.Id == c.AssessmentContentSettingId && c.IsDel == 0 && c.YearMonth.Year == date_Dt.Year && c.YearMonth.Month == date_Dt.Month)
  1754. .Where((a, b) => a.IsDel == 0 && ids.Contains(a.Id))
  1755. .Select((a, b, c) => new TreeNode
  1756. {
  1757. Id = a.Id,
  1758. ContentId = b.Id,
  1759. Name = a.Name,
  1760. ParentId = a.ParentId,
  1761. AssessmentProportion = a.AssessmentProportion, //占比
  1762. AssessmentStandard = a.AssessmentStandard, //描述
  1763. AssessmentProportionChi = b.AssessmentProportionChi, //占比
  1764. UserId = b.UserId,
  1765. JobId = b.JobId,
  1766. AssessmentSettingId = b.AssessmentSettingId,
  1767. Fixed = b.Fixed,
  1768. TargetValue = b.TargetValue,
  1769. AssessmentProportion_Percentage = a.AssessmentProportion * 100,
  1770. HigherUpAssessment = c.HigherUpAssessment,
  1771. HigherUpConfig = c.HigherUpConfig,
  1772. HigherUpUserId = c.HigherUpUserId,
  1773. Score = c.Score,
  1774. ScoreTotal = c.ScoreTotal,
  1775. SelfAssessment = c.SelfAssessment,
  1776. Status = c.Status,
  1777. YearMonth = c.YearMonth,
  1778. })
  1779. .ToList();
  1780. var rootNodeList = List.Where(x => x.ParentId == 0);
  1781. var rootResult = rootNodeList.Select(x => BuildSubTree(x, List));
  1782. jw.Data = rootResult;
  1783. jw.Code = 200;
  1784. jw.Msg = "成功";
  1785. return Ok(jw);
  1786. }
  1787. private TreeNode BuildSubTree(TreeNode parent, List<TreeNode> nodes)
  1788. {
  1789. var children = nodes
  1790. .Where(n => n.ParentId == parent.Id)
  1791. .Select(n => BuildSubTree(n, nodes))
  1792. .ToList();
  1793. parent.Children = children;
  1794. return parent;
  1795. }
  1796. /// <summary>
  1797. /// 绩效项增改
  1798. /// </summary>
  1799. /// <param name="dto"></param>
  1800. /// <returns></returns>
  1801. [HttpPost]
  1802. public async Task<IActionResult> AssessmentSettingOperationAsync(PerAssessmentSettingOperationDto dto)
  1803. {
  1804. var jw = JsonView(false);
  1805. if (!ModelState.IsValid)
  1806. {
  1807. jw.Msg = "参数错误";
  1808. jw.Data = ModelState;
  1809. return Ok(jw);
  1810. }
  1811. try
  1812. {
  1813. if (dto.ParentId != 0)
  1814. {
  1815. var parent = await _sqlSugar.Queryable<Per_AssessmentSetting>().FirstAsync(x=>x.IsDel == 0 && x.Id == dto.ParentId);
  1816. if (parent == null)
  1817. {
  1818. jw.Msg = "父级节点不存在";
  1819. return Ok(jw);
  1820. }
  1821. }
  1822. var entity = new Per_AssessmentSetting
  1823. {
  1824. Name = dto.Name,
  1825. AssessmentProportion = dto.AssessmentProportion,
  1826. AssessmentStandard = dto.AssessmentStandard,
  1827. ParentId = dto.ParentId,
  1828. Id = dto.Id,
  1829. Remark = dto.Remark,
  1830. };
  1831. jw.Code = 200;
  1832. if (dto.Id == 0)
  1833. {
  1834. entity.CreateUserId = dto.CreateId;
  1835. entity.CreateTime = DateTime.Now;
  1836. await _sqlSugar.Insertable(entity).ExecuteCommandAsync();
  1837. jw.Msg = "添加成功!";
  1838. }
  1839. else
  1840. {
  1841. await _sqlSugar.Updateable(entity).ExecuteCommandAsync();
  1842. jw.Msg = "修改成功!";
  1843. }
  1844. }
  1845. catch (Exception ex)
  1846. {
  1847. jw.Msg = "Api error " + ex.Message;
  1848. jw.Code = 400;
  1849. }
  1850. return Ok(jw);
  1851. }
  1852. /// <summary>
  1853. /// 绩效内容增改
  1854. /// </summary>
  1855. /// <param name="dto"></param>
  1856. /// <returns></returns>
  1857. [HttpPost]
  1858. public IActionResult AssessmentSettingOperationContentAsync(AssessmentSettingOperationContenDto dto)
  1859. {
  1860. var jw = JsonView(false, "", "");
  1861. var entity = new Per_AssessmentContentSetting
  1862. {
  1863. AssessmentProportionChi = dto.AssessmentProportionChi,
  1864. AssessmentSettingId = dto.AssessmentSettingId,
  1865. CreateTime = DateTime.Now,
  1866. CreateUserId = dto.CreateUserId,
  1867. Fixed = dto.Fixed,
  1868. Id = dto.Id,
  1869. JobId = dto.JobId,
  1870. TargetValue = dto.TargetValue,
  1871. UserId = dto.UserId,
  1872. Remark = dto.Remark,
  1873. };
  1874. var entity_Fk = _sqlSugar.Queryable<Per_AssessmentSetting>().First(x => x.Id == dto.AssessmentSettingId && x.IsDel == 0);
  1875. if (entity_Fk == null)
  1876. {
  1877. jw.Msg = "考核设置不存在";
  1878. return Ok(jw);
  1879. }
  1880. try
  1881. {
  1882. if (dto.Id == 0)
  1883. {
  1884. //add
  1885. var insertCount = _sqlSugar.Insertable(entity).ExecuteCommand();
  1886. jw.Msg = "添加成功!";
  1887. }
  1888. else
  1889. {
  1890. //update
  1891. var updateCount = _sqlSugar.Updateable(entity).ExecuteCommand();
  1892. jw.Msg = "修改成功!";
  1893. }
  1894. jw.Code = 200;
  1895. }
  1896. catch (Exception ex)
  1897. {
  1898. jw.Msg = "Api error " + ex.Message;
  1899. jw.Code = 400;
  1900. }
  1901. return Ok(jw);
  1902. }
  1903. /// <summary>
  1904. /// 绩效项查询
  1905. /// </summary>
  1906. /// <param name="dto"></param>
  1907. /// <returns></returns>
  1908. [HttpPost]
  1909. public async Task<IActionResult> QueryAssessmentSettingListOffsetAsync(QueryAssessmentSettingListOffsetAsyncDto dto)
  1910. {
  1911. var jw = JsonView(false);
  1912. RefAsync<int> total = 0;//REF和OUT不支持异步,想要真的异步这是最优解
  1913. var entities = await _sqlSugar.Queryable<Per_AssessmentSetting>()
  1914. .Where(x=>x.IsDel == 0)
  1915. .WhereIF(!string.IsNullOrEmpty(dto.SearchValue), e => e.Name.Contains(dto.SearchValue))
  1916. .ToPageListAsync(dto.pageIndex, dto.pageSize, total);
  1917. var DtoResult = entities.Select(e => new
  1918. {
  1919. e.Id,
  1920. Name = e.Name,
  1921. AssessmentProportion = e.AssessmentProportion,
  1922. AssessmentStandard = e.AssessmentStandard,
  1923. ParentId = e.ParentId,
  1924. Remark = e.Remark
  1925. }).ToList();
  1926. jw.Data = new
  1927. {
  1928. total = total.Value,
  1929. dto.pageIndex,
  1930. dto.pageSize,
  1931. List = DtoResult
  1932. };
  1933. jw.Code = 200;
  1934. jw.Msg = "查询成功!";
  1935. return Ok(jw);
  1936. }
  1937. /// <summary>
  1938. /// 绩效分数保存
  1939. /// </summary>
  1940. /// <param name="dto"></param>
  1941. /// <returns></returns>
  1942. [HttpPost]
  1943. public IActionResult SaveUserAssessmen(SaveUserAssessmenDto dto)
  1944. {
  1945. var jw = JsonView(false,"请传入正确的数据!");
  1946. if (dto.Data.Any()) {
  1947. if (!DateTime.TryParse(dto.AssessmenData, out DateTime yearMonth_Dt))
  1948. {
  1949. jw.Data = "月份参数有误!";
  1950. return Ok(jw);
  1951. }
  1952. try
  1953. {
  1954. var ids = dto.Data.Select(x => x.AssessmentContentSettingId).ToList();
  1955. var QueryContent_DB = _sqlSugar.Queryable<Per_AssessmentContentSetting>()
  1956. .InnerJoin<Per_AssessmentSetting>((a, b) => b.IsDel == 0 && a.AssessmentSettingId == b.Id)
  1957. .Where((a, b) => a.IsDel == 0 && ids.Contains(a.Id))
  1958. .Select((a, b) => new
  1959. {
  1960. ContentSettingId = a.Id,
  1961. SettingId = b.Id,
  1962. a.TargetValue,
  1963. b.AssessmentStandard,
  1964. MergeStr = $"【项名称:{b.Name}/目标值:{a.TargetValue}/评估标准:{b.AssessmentStandard}】",
  1965. a.AssessmentProportionChi,
  1966. b.Name
  1967. })
  1968. .ToList()
  1969. .ToDictionary(x => x.ContentSettingId);
  1970. //删除上级未确认数据
  1971. var expressionWhere = Expressionable
  1972. .Create<Per_AssessmentScore>()
  1973. .And(x => x.YearMonth.Year == yearMonth_Dt.Year && x.YearMonth.Month == yearMonth_Dt.Month)
  1974. .And(x => ids.Contains(x.AssessmentContentSettingId))
  1975. .And(x => x.HigherUpConfig == 0)
  1976. .ToExpression();
  1977. _sqlSugar.BeginTran();
  1978. _sqlSugar.Updateable<Per_AssessmentScore>()
  1979. .Where(expressionWhere)
  1980. .SetColumns(x => new Per_AssessmentScore { IsDel = 1, DeleteUserId = dto.CreateUserId, DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") })
  1981. .ExecuteCommand();
  1982. var entityList = new List<Per_AssessmentScore>();
  1983. foreach (var x in dto.Data)
  1984. {
  1985. if (x.HigherUpAssessment > 100 || x.SelfAssessment > 100)
  1986. {
  1987. jw.Msg = QueryContent_DB[x.AssessmentContentSettingId].Name + "项分数不能超过100。";
  1988. return Ok(jw);
  1989. }
  1990. Per_AssessmentScore item = new Per_AssessmentScore
  1991. {
  1992. AssessmentContentSettingId = x.AssessmentContentSettingId,
  1993. CreateTime = DateTime.Now,
  1994. CreateUserId = dto.CreateUserId,
  1995. Details = QueryContent_DB[x.AssessmentContentSettingId].MergeStr,
  1996. HigherUpAssessment = x.HigherUpAssessment,
  1997. HigherUpUserId = x.LeadersId,
  1998. HigherUpConfig = x.HigherUpAssessment > 0 ? 1 : 0,
  1999. SelfAssessment = x.SelfAssessment,
  2000. IsDel = 0,
  2001. Status = x.Status,
  2002. YearMonth = yearMonth_Dt,
  2003. Score = x.SelfAssessment * 0.3M + x.HigherUpAssessment * 0.7M,
  2004. ScoreTotal = (x.SelfAssessment * 0.3M + x.HigherUpAssessment * 0.7M) * QueryContent_DB[x.AssessmentContentSettingId].AssessmentProportionChi,
  2005. };
  2006. entityList.Add(item);
  2007. }
  2008. var influenceRow = _sqlSugar.Insertable(entityList).ExecuteCommand();
  2009. _sqlSugar.CommitTran();
  2010. jw.Code = 200;
  2011. jw.Msg = "保存成功!";
  2012. jw.Data = $"{influenceRow}条数据操作成功!";
  2013. }
  2014. catch (Exception ex)
  2015. {
  2016. _sqlSugar.RollbackTran();
  2017. jw.Code = 500;
  2018. jw.Data = $"API ERROR ({ex.Message})";
  2019. }
  2020. }
  2021. return Ok(jw);
  2022. }
  2023. /// <summary>
  2024. /// 绩效项删除
  2025. /// </summary>
  2026. /// <param name="dto"></param>
  2027. /// <returns></returns>
  2028. [HttpPost]
  2029. public IActionResult DeleteAssessmentSetting(DeleteAssessmentSettingDto dto)
  2030. {
  2031. var jw = JsonView(false, "删除失败!");
  2032. if (!dto.IdArr.Any())
  2033. {
  2034. jw.Msg = "id不能为空!";
  2035. return Ok(jw);
  2036. }
  2037. var rowCount = _sqlSugar.Updateable<Per_AssessmentSetting>()
  2038. .Where(x => dto.IdArr.Contains(x.Id) && x.IsDel == 0)
  2039. .SetColumns(x => new Per_AssessmentSetting
  2040. {
  2041. IsDel = 1,
  2042. DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm"),
  2043. DeleteUserId = dto.UserId,
  2044. })
  2045. .ExecuteCommand();
  2046. jw.Code = 200;
  2047. jw.Msg = $"修改成功!,修改数量{rowCount}";
  2048. return Ok(jw);
  2049. }
  2050. /// <summary>
  2051. /// 绩效内容删除
  2052. /// </summary>
  2053. /// <param name="dto"></param>
  2054. /// <returns></returns>
  2055. [HttpPost]
  2056. public IActionResult DeleteAssessmentContentSetting(DeleteAssessmentSettingDto dto)
  2057. {
  2058. var jw = JsonView(false, "删除失败!");
  2059. if (!dto.IdArr.Any())
  2060. {
  2061. jw.Msg = "id不能为空!";
  2062. return Ok(jw);
  2063. }
  2064. var rowCount = _sqlSugar.Updateable<Per_AssessmentContentSetting>()
  2065. .Where(x => dto.IdArr.Contains(x.Id) && x.IsDel == 0)
  2066. .SetColumns(x => new Per_AssessmentContentSetting
  2067. {
  2068. IsDel = 1,
  2069. DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm"),
  2070. DeleteUserId = dto.UserId,
  2071. })
  2072. .ExecuteCommand();
  2073. jw.Code = 200;
  2074. jw.Msg = $"修改成功!,修改数量{rowCount}";
  2075. return Ok(jw);
  2076. }
  2077. #endregion
  2078. #region 企微Api测试
  2079. [HttpPost]
  2080. public async Task<IActionResult> GetCheckin_MonthDataAsync(DateTime start, DateTime end)
  2081. {
  2082. var jw = JsonView(false);
  2083. jw.Data = await _qiYeWeChatApiService.GetCheckin_MonthDataAsync1(start,end);
  2084. return Ok(jw);
  2085. }
  2086. [HttpPost]
  2087. public async Task<IActionResult> QueryAssessmentByUser(QueryAssessmentByUser Dto)
  2088. {
  2089. var jw = JsonView(false);
  2090. var user_entity = _sqlSugar.Queryable<Sys_Users>()
  2091. .First(e => e.Id == Dto.UserId && e.IsDel == 0);
  2092. var start_Bool = DateTime.TryParse(Dto.Start, out DateTime start);
  2093. var end_Bool = DateTime.TryParse(Dto.End, out DateTime end);
  2094. if (!start_Bool || !end_Bool)
  2095. {
  2096. jw.Msg = "时间格式不正确!";
  2097. return Ok(jw);
  2098. }
  2099. jw.Msg = "用户企业微信Id未绑定!";
  2100. if (user_entity != null && !string.IsNullOrEmpty(user_entity.QiyeChatUserId))
  2101. {
  2102. var data = await _qiYeWeChatApiService.QueryAssessmentByUser(start, end, new List<string> { user_entity.QiyeChatUserId });
  2103. jw.Data = data;
  2104. jw.Msg = "查询成功!";
  2105. jw.Code = 200;
  2106. }
  2107. return Ok(jw);
  2108. }
  2109. [HttpPost]
  2110. public IActionResult TempTest(QueryAssessmentSettingListOffsetAsyncDto Dto)
  2111. {
  2112. var jw = JsonView(false);
  2113. return Ok(jw);
  2114. }
  2115. #endregion
  2116. }
  2117. }