TaskController.cs 33 KB

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