TaskController.cs 32 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849
  1. using System;
  2. using System.Collections;
  3. using System.Collections.Generic;
  4. using System.Globalization;
  5. using System.Linq;
  6. using OASystem.Domain.Dtos.Task;
  7. using OASystem.Domain.Entities.Groups;
  8. using OASystem.Domain.Entities.WorkOrder;
  9. using OASystem.Domain.ViewModels.JuHeExchangeRate;
  10. using OASystem.API.OAMethodLib.QiYeWeChatAPI.AppNotice;
  11. using Dm.util;
  12. namespace OASystem.API.Controllers
  13. {
  14. /// <summary>
  15. /// 部门任务相关
  16. /// </summary>
  17. //[Authorize]
  18. [Route("api/[controller]/[action]")]
  19. public class TaskController : ControllerBase
  20. {
  21. readonly SqlSugarClient _sqlsugar;
  22. public TaskController(SqlSugarClient sqlsugar)
  23. {
  24. _sqlsugar = sqlsugar;
  25. }
  26. [HttpPost]
  27. public async Task<IActionResult> GetTaskList(GetTaskListDto dto)
  28. {
  29. var jw = JsonView(false);
  30. if (dto.TypeId < 1 || dto.UserId < 1)
  31. {
  32. jw.Msg = "参数有误!";
  33. return Ok(jw);
  34. }
  35. DateTime startTime;
  36. DateTime endTime = DateTime.Now;
  37. var expr = Expressionable.Create<Task_WorkOrder>().And(x => x.IsDel == 0)
  38. .And(x => x.TypeId == dto.TypeId)
  39. .And(x => (x.CreateUserId == dto.UserId || x.AssignedUserId == dto.UserId))
  40. .AndIF(!string.IsNullOrEmpty(dto.Search_Name), x => x.Name.Contains(dto.Search_Name))
  41. // .AndIF(dto.Search_UserId > 0, x => (x.CreateUserId == dto.Search_UserId || x.AssignedUserId == dto.Search_UserId))
  42. .AndIF(DateTime.TryParse(dto.Seach_StartTime, out startTime) && DateTime.TryParse(dto.Seach_EndTime, out endTime), x => x.StartTime >= startTime && x.StartTime <= endTime);
  43. var query = _sqlsugar.Queryable<Task_WorkOrder>()
  44. .LeftJoin<Grp_DelegationInfo>((x, y) => x.GroupId == y.Id && y.IsDel == 0)
  45. .LeftJoin<Sys_SetData>((x, y, z) => x.ForeignOptionId == z.Id && z.IsDel == 0)
  46. .LeftJoin<Sys_Users>((x, y, z, w) => x.AssignedUserId == w.Id && w.IsDel == 0)
  47. .Where(expr.ToExpression());
  48. var count = query.Count();
  49. var temp = query.Select((x, y, z, w) => new
  50. {
  51. Id = x.Id,
  52. TaskName = x.Name,
  53. StartTime = x.StartTime.ToString("yyyy-MM-dd HH:mm"),
  54. Assignee = w.CnName,
  55. ExternalOption = z.Name,
  56. Team = y.TeamName,
  57. Active = x.ProgressId,
  58. CreateUserid = x.CreateUserId
  59. });
  60. var list = temp
  61. .OrderByIF(dto.isLv == 1,
  62. x => SqlFunc.IsNull(
  63. SqlFunc.Subqueryable<Task_WorkTask>()
  64. .Where(twt => twt.IsDel == 0 && twt.IsUrgent && twt.WorkOrderId == x.Id)
  65. .Min(twt => twt.StartTime),
  66. DateTime.MaxValue // 把 null 替换成极大值
  67. )
  68. )
  69. .OrderBy(x => x.StartTime)
  70. .ToPageList(dto.PageIndex, dto.PageSize);
  71. var data = list.Select(x =>
  72. {
  73. var taskArr = _sqlsugar.Queryable<Task_WorkTask>()
  74. .Where(y => y.IsDel == 0 && y.WorkOrderId == x.Id)
  75. .ToList();
  76. var ExtraStep = taskArr.Where(x => x.IsExtraTask == true);
  77. var historyStep = _sqlsugar.Queryable<Task_WorkTaskReceipt>()
  78. .Where(y => y.IsDel == 0 && y.WorkOrderId == x.Id
  79. && ExtraStep.Select(z => z.Id).Contains(y.WorkTaskId)
  80. && y.IsApproved == 1)
  81. .Select(x => x.WorkTaskId)
  82. .ToList();
  83. return new WorkOrdeView
  84. {
  85. Id = x.Id,
  86. TaskName = x.TaskName,
  87. StartTime = x.StartTime,
  88. Assignee = x.Assignee,
  89. ExternalOption = x.ExternalOption,
  90. Team = string.IsNullOrWhiteSpace(x.Team) ? "未选择" : x.Team,
  91. StepInfo = new StepInfo
  92. {
  93. Active = x.Active,
  94. ExtraActive = 1,
  95. Steps = taskArr.Where(x => x.IsExtraTask == false)
  96. .OrderBy(x => x.Sort)
  97. .Select(x => new Steps
  98. {
  99. Id = x.Id,
  100. Name = x.Name,
  101. }).ToList(),
  102. ExtraStep = ExtraStep
  103. .OrderBy(x => x.Sort)
  104. .Select(x => new ExtraSteps
  105. {
  106. Id = x.Id,
  107. Name = x.Name,
  108. Approved = historyStep.Contains(x.Id) ? 1 : 0,
  109. }).ToList()
  110. },
  111. isReview = x.CreateUserid == dto.UserId,
  112. UrgentCount = taskArr.Where(x => x.IsUrgent).Count()
  113. };
  114. }).ToList();
  115. jw.Data = data;
  116. jw.Count = count;
  117. jw.Msg = "查询成功!";
  118. jw.Code = 200;
  119. return Ok(jw);
  120. }
  121. /// <summary>
  122. /// 计算两个时间之间的工作小时数
  123. /// 工作时间:周一至周五,上午9:00-12:00,下午13:30-18:00
  124. /// </summary>
  125. /// <param name="startStr">开始时间 "yyyy-MM-dd HH:mm"</param>
  126. /// <param name="endStr">结束时间 "yyyy-MM-dd HH:mm"</param>
  127. /// <returns>工作小时数</returns>
  128. private double CalcWorkHoursExact(string startStr, string endStr)
  129. {
  130. DateTime start = DateTime.ParseExact(startStr, "yyyy-MM-dd HH:mm", CultureInfo.InvariantCulture);
  131. DateTime end = DateTime.ParseExact(endStr, "yyyy-MM-dd HH:mm", CultureInfo.InvariantCulture);
  132. if (end <= start) return 0;
  133. // 每天工作时间段(分钟)
  134. (int Start, int End)[] workPeriods = {
  135. (9 * 60, 12 * 60), // 上午 9:00-12:00
  136. (13 * 60 + 30, 18 * 60) // 下午 13:30-18:00
  137. };
  138. double totalMinutes = 0;
  139. DateTime current = start;
  140. while (current < end)
  141. {
  142. DayOfWeek day = current.DayOfWeek;
  143. if (day >= DayOfWeek.Monday && day <= DayOfWeek.Friday) // 工作日
  144. {
  145. foreach (var period in workPeriods)
  146. {
  147. DateTime periodStart = current.Date.AddMinutes(period.Start);
  148. DateTime periodEnd = current.Date.AddMinutes(period.End);
  149. DateTime effectiveStart = periodStart > current ? periodStart : current;
  150. DateTime effectiveEnd = periodEnd < end ? periodEnd : end;
  151. if (effectiveEnd > effectiveStart)
  152. {
  153. totalMinutes += (effectiveEnd - effectiveStart).TotalMinutes;
  154. }
  155. }
  156. }
  157. // 下一天 0 点
  158. current = current.Date.AddDays(1);
  159. }
  160. return totalMinutes / 60.0; // 转为小时
  161. }
  162. /// <summary>
  163. /// 根据开始时间和工作小时数,计算结束日期时间
  164. /// </summary>
  165. /// <param name="start">开始时间</param>
  166. /// <param name="workHours">工作小时数</param>
  167. /// <returns>结束时间</returns>
  168. private DateTime CalcEndDate(DateTime start, double workHours)
  169. {
  170. // 工作时间段(分钟)
  171. (int Start, int End)[] workPeriods = {
  172. (9 * 60, 12 * 60), // 上午 9:00-12:00
  173. (13 * 60 + 30, 18 * 60) // 下午 13:30-18:00
  174. };
  175. double remainingMinutes = workHours * 60;
  176. DateTime current = start;
  177. while (remainingMinutes > 0)
  178. {
  179. DayOfWeek day = current.DayOfWeek;
  180. if (day >= DayOfWeek.Monday && day <= DayOfWeek.Friday) // 工作日
  181. {
  182. foreach (var period in workPeriods)
  183. {
  184. DateTime periodStart = current.Date.AddMinutes(period.Start);
  185. DateTime periodEnd = current.Date.AddMinutes(period.End);
  186. // 如果当前时间超过本段结束,则跳过
  187. if (current >= periodEnd) continue;
  188. // 当前段开始时间
  189. DateTime effectiveStart = current > periodStart ? current : periodStart;
  190. double availableMinutes = (periodEnd - effectiveStart).TotalMinutes;
  191. if (availableMinutes >= remainingMinutes)
  192. {
  193. // 剩余工作时间在本段可以完成
  194. return effectiveStart.AddMinutes(remainingMinutes);
  195. }
  196. else
  197. {
  198. remainingMinutes -= availableMinutes;
  199. }
  200. }
  201. }
  202. // 下一天 0点
  203. current = current.Date.AddDays(1);
  204. current = current.Date.AddHours(0);
  205. }
  206. return current; // 理论上不会到这里
  207. }
  208. private string GetAdjustedStartTime()
  209. {
  210. // 获取当前时间
  211. DateTime now = DateTime.Now;
  212. // 获取年月日、小时和分钟
  213. int year = now.Year;
  214. int month = now.Month;
  215. int day = now.Day;
  216. int hours = now.Hour;
  217. int minutes = now.Minute;
  218. // 调整分钟数,使其能被10整除
  219. if (minutes % 10 != 0)
  220. {
  221. minutes = (int)Math.Ceiling(minutes / 10.0) * 10;
  222. // 如果分钟超过59,则进位到下一小时
  223. if (minutes > 59)
  224. {
  225. minutes = 0;
  226. hours++;
  227. // 如果小时进位到24,则日期需要增加一天
  228. if (hours >= 24)
  229. {
  230. hours = 0;
  231. // 如果小时为24,日期需要增加一天
  232. DateTime nextDay = now.AddDays(1);
  233. year = nextDay.Year;
  234. month = nextDay.Month;
  235. day = nextDay.Day;
  236. }
  237. }
  238. }
  239. // 格式化时间为 "yyyy-MM-dd HH:mm"
  240. return new DateTime(year, month, day, hours, minutes, 0).ToString("yyyy-MM-dd HH:mm");
  241. }
  242. /// <summary>
  243. /// 新增/编辑操作基本数据
  244. /// </summary>
  245. /// <param name="dto"></param>
  246. /// <returns></returns>
  247. [HttpPost]
  248. public async Task<IActionResult> TaskInit(TaskInitDto dto)
  249. {
  250. if (dto.TypeId < 1)
  251. {
  252. return Ok(JsonView(false, "参数有误!"));
  253. }
  254. var jw = JsonView(false);
  255. var groupList = _sqlsugar.Queryable<Grp_DelegationInfo>().Where(x => x.IsDel == 0).OrderByDescending(x => x.VisitStartDate).Select(x => new { x.Id, x.TeamName }).ToList();
  256. groupList.Insert(0, new { Id = -1, TeamName = "未选择" });
  257. var setdataids = new List<int>() { 122, 123 };
  258. var setData = _sqlsugar.Queryable<Sys_SetData>().Where(x => x.IsDel == 0 && setdataids.Contains(x.STid)).Select(x => new
  259. {
  260. x.Id,
  261. x.STid,
  262. x.Name
  263. }).ToList();
  264. var taskLv = setData.Where(x => x.STid == 122);
  265. var foreignLv = setData.Where(x => x.STid == 123);
  266. var users = _sqlsugar.Queryable<Sys_Users>().Where(x => x.IsDel == 0).Select(x => new { x.Id, x.CnName }).ToList();
  267. users.Insert(0, new { Id = 0, CnName = "未选择" });
  268. var defaultTask = new ArrayList();
  269. var startTime = GetAdjustedStartTime();
  270. if (DateTime.TryParse(startTime, out DateTime thisTime))
  271. {
  272. var taskArr = _sqlsugar.Queryable<Task_WorkOrderDefault>()
  273. .Where(x => x.IsDel == 0 && x.TypeId == dto.TypeId)
  274. .OrderBy(x => x.Sort).ToList();
  275. var i = 1;
  276. foreach (var item in taskArr)
  277. {
  278. var endTime = CalcEndDate(thisTime, item.DurationHours);
  279. defaultTask.Add(new WorkTaskView
  280. {
  281. Name = item.Name,
  282. PriorityId = item.PriorityId,
  283. IsUrgent = item.IsUrgent,
  284. StartTime = thisTime,
  285. EndTime = endTime,
  286. DurationHours = item.DurationHours,
  287. IsExtraTask = false,
  288. Sort = i
  289. });
  290. i++;
  291. thisTime = endTime;
  292. }
  293. }
  294. var data = new
  295. {
  296. GroupList = groupList,
  297. TaskLv = taskLv,
  298. ForeignLv = foreignLv,
  299. Users = users,
  300. DefaultTask = defaultTask,
  301. startTime
  302. };
  303. jw.Data = data;
  304. jw.Code = 200;
  305. jw.Msg = "SUCCESS!";
  306. return Ok(jw);
  307. }
  308. [HttpPost]
  309. public async Task<IActionResult> TaskDetail(TaskDetailDto dto)
  310. {
  311. var jw = JsonView(false);
  312. var groupList = _sqlsugar.Queryable<Grp_DelegationInfo>().Where(x => x.IsDel == 0).OrderByDescending(x => x.VisitStartDate).Select(x => new { x.Id, x.TeamName }).ToList();
  313. groupList.Insert(0, new { Id = -1, TeamName = "未选择" });
  314. var setdataids = new List<int>() { 122, 123 };
  315. var setData = _sqlsugar.Queryable<Sys_SetData>().Where(x => x.IsDel == 0 && setdataids.Contains(x.STid)).Select(x => new
  316. {
  317. x.Id,
  318. x.STid,
  319. x.Name
  320. }).ToList();
  321. var taskLv = setData.Where(x => x.STid == 122);
  322. var foreignLv = setData.Where(x => x.STid == 123);
  323. var users = _sqlsugar.Queryable<Sys_Users>().Where(x => x.IsDel == 0).Select(x => new { x.Id, x.CnName }).ToList();
  324. users.Insert(0, new { Id = 0, CnName = "未选择" });
  325. var workOrder = _sqlsugar.Queryable<Task_WorkOrder>().First(x => x.Id == dto.Id && x.IsDel == 0);
  326. var tasks = _sqlsugar.Queryable<Task_WorkTask>()
  327. .Where(x => x.IsDel == 0 && x.WorkOrderId == workOrder.Id)
  328. .OrderBy(x => x.Sort)
  329. .Select<WorkTaskView>()
  330. .ToList();
  331. var data = new
  332. {
  333. GroupList = groupList,
  334. TaskLv = taskLv,
  335. ForeignLv = foreignLv,
  336. Users = users,
  337. workOrder = new
  338. {
  339. workOrder.Id,
  340. workOrder.Name,
  341. workOrder.Remark,
  342. workOrder.AssignedUserId,
  343. workOrder.ForeignOptionId,
  344. workOrder.GroupId,
  345. workOrder.StartTime,
  346. Action = workOrder.ProgressId
  347. },
  348. mainTask = tasks.Where(x => x.IsExtraTask == false).ToList(),
  349. extraTask = tasks.Where(x => x.IsExtraTask == true).ToList()
  350. };
  351. jw.Data = data;
  352. jw.Code = 200;
  353. jw.Msg = "SUCCESS!";
  354. return Ok(jw);
  355. }
  356. /// <summary>
  357. /// 新增/编辑操作
  358. /// </summary>
  359. /// <param name="dto"></param>
  360. /// <returns></returns>
  361. [HttpPost]
  362. public async Task<IActionResult> TaskOperation(TaskOperationDto dto)
  363. {
  364. var jw = JsonView(false);
  365. jw.Data = "";
  366. if (dto.TypeId < 1 || dto.AssignedUserId < 1)
  367. {
  368. return Ok(JsonView(false, "参数有误!"));
  369. }
  370. if (!DateTime.TryParse(dto.StartTime, out DateTime startTime))
  371. {
  372. return Ok(JsonView(false, "时间格式不正确!"));
  373. }
  374. Task_WorkOrder workOrder = new Task_WorkOrder
  375. {
  376. Id = dto.Id,
  377. AssignedUserId = dto.AssignedUserId,
  378. CreateTime = DateTime.Now,
  379. CreateUserId = dto.CreateUserId,
  380. ForeignOptionId = dto.ForeignOptionId,
  381. GroupId = dto.GroupId,
  382. ProgressId = dto.Action,
  383. TypeId = dto.TypeId,
  384. IsDel = 0,
  385. Name = dto.Name,
  386. StartTime = startTime,
  387. };
  388. if (dto.Id == 0)
  389. {
  390. _sqlsugar.BeginTran();
  391. try
  392. {
  393. var workOrderId = _sqlsugar.Insertable<Task_WorkOrder>(workOrder).ExecuteReturnIdentity();
  394. workOrder.Id = workOrderId;
  395. List<Task_WorkTask> workTasks = dto.Tasks.Select(x => new Task_WorkTask
  396. {
  397. AssignedUserId = x.AssignedUserId,
  398. CreateTime = DateTime.Now,
  399. CreateUserId = dto.CreateUserId,
  400. DurationHours = x.DurationHours,
  401. IsUrgent = x.IsUrgent,
  402. PriorityId = x.PriorityId,
  403. WorkOrderId = workOrderId,
  404. IsDel = 0,
  405. StartTime = x.StartTime,
  406. EndTime = x.EndTime,
  407. IsExtraTask = x.IsExtraTask,
  408. Name = x.Name,
  409. Sort = x.Sort
  410. }).ToList();
  411. _sqlsugar.Insertable(workTasks).ExecuteCommand();
  412. _sqlsugar.CommitTran();
  413. jw.Code = 200;
  414. jw.Msg = "SUCCESS!";
  415. }
  416. catch (Exception ex)
  417. {
  418. _sqlsugar.RollbackTran();
  419. jw.Code = 500;
  420. jw.Msg = ex.Message;
  421. }
  422. }
  423. else
  424. {
  425. _sqlsugar.BeginTran();
  426. try
  427. {
  428. var workOrderId = workOrder.Id;
  429. _sqlsugar.Updateable<Task_WorkOrder>(workOrder)
  430. .IgnoreColumns(x => new { x.CreateTime, x.CreateUserId })
  431. .ExecuteCommand();
  432. List<Task_WorkTask> workTasks = dto.Tasks.Select(x => new Task_WorkTask
  433. {
  434. Id = x.Id,
  435. AssignedUserId = x.AssignedUserId,
  436. DurationHours = x.DurationHours,
  437. IsUrgent = x.IsUrgent,
  438. PriorityId = x.PriorityId,
  439. WorkOrderId = workOrderId,
  440. IsDel = 0,
  441. StartTime = x.StartTime,
  442. EndTime = x.EndTime,
  443. IsExtraTask = x.IsExtraTask,
  444. Name = x.Name,
  445. Sort = x.Sort
  446. }).ToList();
  447. var insertArr = workTasks.Where(x => x.Id == 0).ToList();
  448. var updateArr = workTasks.Where(x => x.Id > 0).ToList();
  449. var notdeleteArr = updateArr.Select(x => x.Id);
  450. _sqlsugar.Updateable<Task_WorkTask>().Where(x => x.WorkOrderId == workOrderId && !notdeleteArr.Contains(x.Id))
  451. .SetColumns(x => new Task_WorkTask
  452. {
  453. IsDel = 1,
  454. DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm"),
  455. DeleteUserId = dto.CreateUserId
  456. })
  457. .ExecuteCommand();
  458. if (insertArr.Any())
  459. {
  460. _sqlsugar.Insertable(insertArr).ExecuteCommand();
  461. }
  462. if (updateArr.Any())
  463. {
  464. _sqlsugar.Updateable(updateArr)
  465. .IgnoreColumns(x => new { x.CreateTime, x.CreateUserId })
  466. .ExecuteCommand();
  467. }
  468. _sqlsugar.CommitTran();
  469. jw.Code = 200;
  470. jw.Msg = "SUCCESS!";
  471. }
  472. catch (Exception ex)
  473. {
  474. _sqlsugar.RollbackTran();
  475. jw.Code = 500;
  476. jw.Msg = ex.Message;
  477. }
  478. }
  479. _ = AppNoticeLibrary.SendUserMsg_Task_ToUser(workOrder.Id,
  480. new List<string>() { dto.AssignedUserId.toString(), "235" }
  481. , dto.Id == 0);
  482. return Ok(jw);
  483. }
  484. [HttpPost]
  485. public async Task<IActionResult> GetWorkTaskReceipt(GetWorkTaskReceiptDto dto)
  486. {
  487. var jw = JsonView(false);
  488. if (dto.OrderId < 1 || dto.TaskId < 1)
  489. {
  490. jw.Msg = "参数有误!";
  491. return Ok(jw);
  492. }
  493. var data = _sqlsugar.Queryable<Task_WorkTaskReceipt>()
  494. .Where(x => x.WorkOrderId == dto.OrderId && x.WorkTaskId == dto.TaskId && x.IsDel == 0)
  495. .Select<WorkTaskReceiptView>()
  496. .ToList()
  497. .Select(x =>
  498. {
  499. var Files = JsonConvert.DeserializeObject<List<string>>(x.FilePath);
  500. return new
  501. {
  502. x.WorkTaskId,
  503. x.WorkOrderId,
  504. x.Remark,
  505. x.Id,
  506. x.RejectReason,
  507. x.Content,
  508. x.IsApproved,
  509. x.IsCompleted,
  510. Files = Files.Select(y =>
  511. {
  512. var sp = y.Split('/');
  513. string filename = sp[sp.Length - 1];
  514. string ftpUrl = AppSettingsHelper.Get("TaskFileBaseUrl") + y.Replace(AppSettingsHelper.Get("TaskFileBasePath"), AppSettingsHelper.Get("TaskFileFtpPath"));
  515. return new
  516. {
  517. FileName = filename,
  518. Url = ftpUrl,
  519. };
  520. })
  521. };
  522. });
  523. jw.Data = data;
  524. jw.Code = 200;
  525. jw.Msg = "SUCCESS";
  526. return Ok(jw);
  527. }
  528. [HttpPost]
  529. public async Task<IActionResult> SubmitWorkTaskReceipt([FromForm] SubmitWorkTaskReceiptDto dto)
  530. {
  531. var jw = JsonView(false);
  532. jw.Data = "";
  533. var orderInfo = _sqlsugar.Queryable<Task_WorkOrder>().First(x => x.Id == dto.WorkOrderId);
  534. if (orderInfo == null)
  535. {
  536. jw.Msg = "参数有误!";
  537. return Ok(jw);
  538. }
  539. var filePathArr = new List<string>();
  540. if (dto.Files != null && dto.Files.Count > 0)
  541. {
  542. string winPath = AppSettingsHelper.Get("TaskFileBasePath") + $"{orderInfo.Name}/";
  543. if (!Directory.Exists(winPath))
  544. {
  545. Directory.CreateDirectory(winPath);
  546. }
  547. //保存文件
  548. foreach (var item in dto.Files)
  549. {
  550. var fileName = item.FileName;
  551. var saveFilePath = winPath + fileName;
  552. using (FileStream fs = System.IO.File.Create(saveFilePath))
  553. {
  554. item.CopyTo(fs);
  555. fs.Flush();
  556. }
  557. filePathArr.Add(saveFilePath);
  558. }
  559. }
  560. var task = _sqlsugar.Queryable<Task_WorkTask>().
  561. First(x => x.Id == dto.WorkTaskId && x.IsDel == 0);
  562. if (task == null)
  563. {
  564. jw.Msg = "任务不存在或已删除!";
  565. return Ok(jw);
  566. }
  567. Task_WorkTaskReceipt data = new Task_WorkTaskReceipt
  568. {
  569. Content = dto.Content,
  570. CreateTime = DateTime.Now,
  571. CreateUserId = dto.UserId,
  572. IsApproved = 0,
  573. IsCompleted = dto.IsCompleted,
  574. WorkTaskId = dto.WorkTaskId,
  575. WorkOrderId = dto.WorkOrderId,
  576. FilePath = JsonConvert.SerializeObject(filePathArr)
  577. };
  578. var count = _sqlsugar.Insertable(data).ExecuteCommand();
  579. if (count > 0)
  580. {
  581. _ = AppNoticeLibrary.SendUserMsg_TaskSubMit_ToUser(task.Id,
  582. new List<string>() { task.CreateUserId.toString() });
  583. }
  584. jw.Code = 200;
  585. jw.Msg = $"{count}条回执单、{dto.Files}个文件保存成功!";
  586. return Ok(jw);
  587. }
  588. /// <summary>
  589. /// 软删除工作订单
  590. /// </summary>
  591. /// <param name="dto">删除参数</param>
  592. /// <returns></returns>
  593. [HttpPost]
  594. public async Task<IActionResult> SoftDeleteWorkOrder(SoftDeleteWorkOrderDto dto)
  595. {
  596. var jw = JsonView(false);
  597. if (dto.WorkOrderId < 1 || dto.UserId < 1)
  598. {
  599. jw.Msg = "参数有误!";
  600. return Ok(jw);
  601. }
  602. // 检查工作订单是否存在且未被删除
  603. var workOrder = _sqlsugar.Queryable<Task_WorkOrder>()
  604. .First(x => x.Id == dto.WorkOrderId && x.IsDel == 0);
  605. if (workOrder == null)
  606. {
  607. jw.Msg = "工作订单不存在或已被删除!";
  608. return Ok(jw);
  609. }
  610. // 检查权限:只有创建者或管理员可以删除
  611. if (workOrder.CreateUserId != dto.UserId)
  612. {
  613. jw.Msg = "权限不足,无法删除此工作订单!";
  614. return Ok(jw);
  615. }
  616. _sqlsugar.BeginTran();
  617. try
  618. {
  619. // 软删除工作订单
  620. var updateWorkOrderResult = _sqlsugar.Updateable<Task_WorkOrder>()
  621. .SetColumns(x => new Task_WorkOrder
  622. {
  623. IsDel = 1,
  624. DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  625. DeleteUserId = dto.UserId
  626. })
  627. .Where(x => x.Id == dto.WorkOrderId)
  628. .ExecuteCommand();
  629. // 软删除相关的工作任务
  630. var updateWorkTaskResult = _sqlsugar.Updateable<Task_WorkTask>()
  631. .SetColumns(x => new Task_WorkTask
  632. {
  633. IsDel = 1,
  634. DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  635. DeleteUserId = dto.UserId
  636. })
  637. .Where(x => x.WorkOrderId == dto.WorkOrderId)
  638. .ExecuteCommand();
  639. // 软删除相关的回执单
  640. var updateReceiptResult = _sqlsugar.Updateable<Task_WorkTaskReceipt>()
  641. .SetColumns(x => new Task_WorkTaskReceipt
  642. {
  643. IsDel = 1,
  644. DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  645. DeleteUserId = dto.UserId
  646. })
  647. .Where(x => x.WorkOrderId == dto.WorkOrderId)
  648. .ExecuteCommand();
  649. _sqlsugar.CommitTran();
  650. jw.Code = 200;
  651. jw.Msg = "工作订单删除成功!";
  652. jw.Data = new
  653. {
  654. WorkOrderId = dto.WorkOrderId,
  655. DeletedWorkTasks = updateWorkTaskResult,
  656. DeletedReceipts = updateReceiptResult,
  657. DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  658. };
  659. }
  660. catch (Exception ex)
  661. {
  662. _sqlsugar.RollbackTran();
  663. jw.Code = 500;
  664. jw.Msg = $"删除失败:{ex.Message}";
  665. }
  666. return Ok(jw);
  667. }
  668. /// <summary>
  669. /// 回执审核
  670. /// </summary>
  671. /// <param name="dto"></param>
  672. /// <returns></returns>
  673. [HttpPost]
  674. public async Task<IActionResult> AuditWorkTaskReceipt(AuditWorkTaskReceiptDto dto)
  675. {
  676. var jw = JsonView(false);
  677. if (dto.ReceiptId < 1 || dto.ApproverId < 1)
  678. {
  679. jw.Msg = "参数有误!";
  680. return Ok(jw);
  681. }
  682. if (dto.Approve == -1 && string.IsNullOrWhiteSpace(dto.RejectReason))
  683. {
  684. jw.Msg = "驳回必须填写原因!";
  685. return Ok(jw);
  686. }
  687. var receipt = _sqlsugar.Queryable<Task_WorkTaskReceipt>()
  688. .Includes<Task_WorkTask>(o => o.WorkTask)
  689. .First(x => x.Id == dto.ReceiptId && x.IsDel == 0);
  690. if (receipt == null)
  691. {
  692. jw.Msg = "回执单不存在或已删除!";
  693. return Ok(jw);
  694. }
  695. try
  696. {
  697. _sqlsugar.BeginTran();
  698. var existsApproved = _sqlsugar.Queryable<Task_WorkTaskReceipt>()
  699. .First(x => x.WorkOrderId == receipt.WorkOrderId && x.WorkTaskId == receipt.WorkTaskId && x.IsDel == 0 && x.IsApproved == 1);
  700. var affected = _sqlsugar.Updateable<Task_WorkTaskReceipt>()
  701. .SetColumns(x => new Task_WorkTaskReceipt
  702. {
  703. IsApproved = dto.Approve,
  704. RejectReason = dto.Approve == -1 ? dto.RejectReason : ""
  705. })
  706. .Where(x => x.Id == dto.ReceiptId)
  707. .ExecuteCommand();
  708. if (existsApproved == null && dto.Approve == 1 && !receipt.WorkTask.IsExtraTask)
  709. {
  710. _sqlsugar.Updateable<Task_WorkOrder>()
  711. .SetColumns(x => new Task_WorkOrder
  712. {
  713. ProgressId = x.ProgressId + 1
  714. })
  715. .Where(x => x.Id == receipt.WorkOrderId)
  716. .ExecuteCommand();
  717. }
  718. _sqlsugar.CommitTran();
  719. //企微通知
  720. _ = AppNoticeLibrary.SendUserMsg_TaskAudit_ToUser
  721. (receipt.WorkTaskId, dto.Approve == 1,
  722. dto.RejectReason,
  723. new List<string>() { receipt.WorkTask.AssignedUserId.toString() });
  724. jw.Code = 200;
  725. jw.Msg = "审核完成!";
  726. jw.Data = new
  727. {
  728. dto.ReceiptId,
  729. Status = dto.Approve == 1 ? "审核通过" : "审核驳回",
  730. dto.RejectReason,
  731. receipt.WorkOrderId,
  732. Affected = affected
  733. };
  734. }
  735. catch (Exception ex)
  736. {
  737. _sqlsugar.RollbackTran();
  738. jw.Code = 500;
  739. jw.Msg = $"审核失败:{ex.Message}";
  740. }
  741. return Ok(jw);
  742. }
  743. }
  744. }