PersonnelModuleController.cs 128 KB

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