TaskController.cs 36 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956
  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. Remark = item.Remark
  295. });
  296. i++;
  297. thisTime = endTime;
  298. }
  299. }
  300. var data = new
  301. {
  302. GroupList = groupList,
  303. TaskLv = taskLv,
  304. ForeignLv = foreignLv,
  305. Users = users,
  306. DefaultTask = defaultTask,
  307. startTime
  308. };
  309. jw.Data = data;
  310. jw.Code = 200;
  311. jw.Msg = "SUCCESS!";
  312. return Ok(jw);
  313. }
  314. /// <summary>
  315. /// 工单详情
  316. /// </summary>
  317. /// <param name="dto"></param>
  318. /// <returns></returns>
  319. [HttpPost]
  320. public async Task<IActionResult> TaskDetail(TaskDetailDto dto)
  321. {
  322. var jw = JsonView(false);
  323. var groupList = _sqlsugar.Queryable<Grp_DelegationInfo>().Where(x => x.IsDel == 0).OrderByDescending(x => x.VisitStartDate).Select(x => new { x.Id, x.TeamName }).ToList();
  324. groupList.Insert(0, new { Id = -1, TeamName = "未选择" });
  325. var setdataids = new List<int>() { 122, 123 };
  326. var setData = _sqlsugar.Queryable<Sys_SetData>().Where(x => x.IsDel == 0 && setdataids.Contains(x.STid)).Select(x => new
  327. {
  328. x.Id,
  329. x.STid,
  330. x.Name
  331. }).ToList();
  332. var taskLv = setData.Where(x => x.STid == 122);
  333. var foreignLv = setData.Where(x => x.STid == 123);
  334. var users = _sqlsugar.Queryable<Sys_Users>().Where(x => x.IsDel == 0).Select(x => new { x.Id, x.CnName }).ToList();
  335. users.Insert(0, new { Id = 0, CnName = "未选择" });
  336. var workOrder = _sqlsugar.Queryable<Task_WorkOrder>().First(x => x.Id == dto.Id && x.IsDel == 0);
  337. var tasks = _sqlsugar.Queryable<Task_WorkTask>()
  338. .Where(x => x.IsDel == 0 && x.WorkOrderId == workOrder.Id)
  339. .OrderBy(x => x.Sort)
  340. .Select<WorkTaskView>()
  341. .ToList();
  342. var data = new
  343. {
  344. GroupList = groupList,
  345. TaskLv = taskLv,
  346. ForeignLv = foreignLv,
  347. Users = users,
  348. workOrder = new
  349. {
  350. workOrder.Id,
  351. workOrder.Name,
  352. workOrder.Remark,
  353. workOrder.AssignedUserId,
  354. workOrder.ForeignOptionId,
  355. workOrder.GroupId,
  356. workOrder.StartTime,
  357. Action = workOrder.ProgressId
  358. },
  359. mainTask = tasks.Where(x => x.IsExtraTask == false).ToList(),
  360. extraTask = tasks.Where(x => x.IsExtraTask == true).ToList()
  361. };
  362. jw.Data = data;
  363. jw.Code = 200;
  364. jw.Msg = "SUCCESS!";
  365. return Ok(jw);
  366. }
  367. /// <summary>
  368. /// 新增/编辑操作
  369. /// </summary>
  370. /// <param name="dto"></param>
  371. /// <returns></returns>
  372. [HttpPost]
  373. public async Task<IActionResult> TaskOperation(TaskOperationDto dto)
  374. {
  375. var jw = JsonView(false);
  376. jw.Data = "";
  377. if (dto.TypeId < 1 || dto.AssignedUserId < 1)
  378. {
  379. return Ok(JsonView(false, "参数有误!"));
  380. }
  381. if (!DateTime.TryParse(dto.StartTime, out DateTime startTime))
  382. {
  383. return Ok(JsonView(false, "时间格式不正确!"));
  384. }
  385. Task_WorkOrder workOrder = new Task_WorkOrder
  386. {
  387. Id = dto.Id,
  388. AssignedUserId = dto.AssignedUserId,
  389. CreateTime = DateTime.Now,
  390. CreateUserId = dto.CreateUserId,
  391. ForeignOptionId = dto.ForeignOptionId,
  392. GroupId = dto.GroupId,
  393. ProgressId = dto.Action,
  394. TypeId = dto.TypeId,
  395. IsDel = 0,
  396. Name = dto.Name,
  397. StartTime = startTime,
  398. };
  399. if (dto.Id == 0)
  400. {
  401. _sqlsugar.BeginTran();
  402. try
  403. {
  404. var workOrderId = _sqlsugar.Insertable<Task_WorkOrder>(workOrder).ExecuteReturnIdentity();
  405. workOrder.Id = workOrderId;
  406. List<Task_WorkTask> workTasks = dto.Tasks.Select(x => new Task_WorkTask
  407. {
  408. AssignedUserId = x.AssignedUserId,
  409. CreateTime = DateTime.Now,
  410. CreateUserId = dto.CreateUserId,
  411. DurationHours = x.DurationHours,
  412. IsUrgent = x.IsUrgent,
  413. PriorityId = x.PriorityId,
  414. WorkOrderId = workOrderId,
  415. IsDel = 0,
  416. StartTime = x.StartTime,
  417. EndTime = x.EndTime,
  418. IsExtraTask = x.IsExtraTask,
  419. Name = x.Name,
  420. Sort = x.Sort,
  421. Remark = x.Remark
  422. }).ToList();
  423. _sqlsugar.Insertable(workTasks).ExecuteCommand();
  424. _sqlsugar.CommitTran();
  425. jw.Code = 200;
  426. jw.Msg = "SUCCESS!";
  427. }
  428. catch (Exception ex)
  429. {
  430. _sqlsugar.RollbackTran();
  431. jw.Code = 500;
  432. jw.Msg = ex.Message;
  433. }
  434. }
  435. else
  436. {
  437. _sqlsugar.BeginTran();
  438. try
  439. {
  440. var workOrderId = workOrder.Id;
  441. _sqlsugar.Updateable<Task_WorkOrder>(workOrder)
  442. .IgnoreColumns(x => new { x.CreateTime, x.CreateUserId })
  443. .ExecuteCommand();
  444. List<Task_WorkTask> workTasks = dto.Tasks.Select(x => new Task_WorkTask
  445. {
  446. Id = x.Id,
  447. AssignedUserId = x.AssignedUserId,
  448. DurationHours = x.DurationHours,
  449. IsUrgent = x.IsUrgent,
  450. PriorityId = x.PriorityId,
  451. WorkOrderId = workOrderId,
  452. IsDel = 0,
  453. StartTime = x.StartTime,
  454. EndTime = x.EndTime,
  455. IsExtraTask = x.IsExtraTask,
  456. Name = x.Name,
  457. Sort = x.Sort,
  458. Remark = x.Remark
  459. }).ToList();
  460. var insertArr = workTasks.Where(x => x.Id == 0).ToList();
  461. var updateArr = workTasks.Where(x => x.Id > 0).ToList();
  462. var notdeleteArr = updateArr.Select(x => x.Id);
  463. _sqlsugar.Updateable<Task_WorkTask>().Where(x => x.WorkOrderId == workOrderId && !notdeleteArr.Contains(x.Id))
  464. .SetColumns(x => new Task_WorkTask
  465. {
  466. IsDel = 1,
  467. DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm"),
  468. DeleteUserId = dto.CreateUserId
  469. })
  470. .ExecuteCommand();
  471. if (insertArr.Any())
  472. {
  473. insertArr.ForEach(x =>
  474. {
  475. x.CreateUserId = dto.CreateUserId;
  476. x.CreateTime = DateTime.Now;
  477. });
  478. _sqlsugar.Insertable(insertArr).ExecuteCommand();
  479. }
  480. if (updateArr.Any())
  481. {
  482. _sqlsugar.Updateable(updateArr)
  483. .IgnoreColumns(x => new { x.CreateTime, x.CreateUserId })
  484. .ExecuteCommand();
  485. }
  486. _sqlsugar.CommitTran();
  487. jw.Code = 200;
  488. jw.Msg = "SUCCESS!";
  489. }
  490. catch (Exception ex)
  491. {
  492. _sqlsugar.RollbackTran();
  493. jw.Code = 500;
  494. jw.Msg = ex.Message;
  495. }
  496. }
  497. _ = AppNoticeLibrary.SendUserMsg_Task_ToUser(workOrder.Id,
  498. new List<string>() { dto.AssignedUserId.toString(), "235" }
  499. , dto.Id == 0);
  500. return Ok(jw);
  501. }
  502. /// <summary>
  503. /// 获取历史回执数据
  504. /// </summary>
  505. /// <param name="dto"></param>
  506. /// <returns></returns>
  507. [HttpPost]
  508. public async Task<IActionResult> GetWorkTaskReceipt(GetWorkTaskReceiptDto dto)
  509. {
  510. var jw = JsonView(false);
  511. if (dto.OrderId < 1 || dto.TaskId < 1)
  512. {
  513. jw.Msg = "参数有误!";
  514. return Ok(jw);
  515. }
  516. var data = _sqlsugar.Queryable<Task_WorkTaskReceipt>()
  517. .Where(x => x.WorkOrderId == dto.OrderId && x.WorkTaskId == dto.TaskId && x.IsDel == 0)
  518. .Select<WorkTaskReceiptView>()
  519. .ToList()
  520. .Select(x =>
  521. {
  522. var Files = JsonConvert.DeserializeObject<List<string>>(x.FilePath) ?? new
  523. List<string>();
  524. return new
  525. {
  526. x.WorkTaskId,
  527. x.WorkOrderId,
  528. x.Remark,
  529. x.Id,
  530. x.RejectReason,
  531. x.Content,
  532. x.IsApproved,
  533. x.IsCompleted,
  534. Files = Files.Select(y =>
  535. {
  536. var sp = y.Split('/');
  537. string filename = sp[sp.Length - 1];
  538. string ftpUrl = AppSettingsHelper.Get("TaskFileBaseUrl") + y.Replace(AppSettingsHelper.Get("TaskFileBasePath"), AppSettingsHelper.Get("TaskFileFtpPath"));
  539. return new
  540. {
  541. FileName = filename,
  542. Url = ftpUrl,
  543. };
  544. })
  545. };
  546. });
  547. jw.Data = data;
  548. jw.Code = 200;
  549. jw.Msg = "SUCCESS";
  550. return Ok(jw);
  551. }
  552. /// <summary>
  553. /// 任务回执提交
  554. /// </summary>
  555. /// <param name="dto"></param>
  556. /// <returns></returns>
  557. [HttpPost]
  558. public async Task<IActionResult> SubmitWorkTaskReceipt([FromForm] SubmitWorkTaskReceiptDto dto)
  559. {
  560. var jw = JsonView(false);
  561. jw.Data = "";
  562. var orderInfo = _sqlsugar.Queryable<Task_WorkOrder>().First(x => x.Id == dto.WorkOrderId && x.IsDel == 0);
  563. if (orderInfo == null)
  564. {
  565. jw.Msg = "参数有误!";
  566. return Ok(jw);
  567. }
  568. var filePathArr = new List<string>();
  569. if (dto.Files != null && dto.Files.Count > 0)
  570. {
  571. string winPath = AppSettingsHelper.Get("TaskFileBasePath") + $"{orderInfo.Name}/";
  572. if (!Directory.Exists(winPath))
  573. {
  574. Directory.CreateDirectory(winPath);
  575. }
  576. //保存文件
  577. foreach (var item in dto.Files)
  578. {
  579. var fileName = item.FileName;
  580. var saveFilePath = winPath + fileName;
  581. using (FileStream fs = System.IO.File.Create(saveFilePath))
  582. {
  583. item.CopyTo(fs);
  584. fs.Flush();
  585. }
  586. filePathArr.Add(saveFilePath);
  587. }
  588. }
  589. var task = _sqlsugar.Queryable<Task_WorkTask>().
  590. First(x => x.Id == dto.WorkTaskId && x.IsDel == 0);
  591. if (task == null)
  592. {
  593. jw.Msg = "任务不存在或已删除!";
  594. return Ok(jw);
  595. }
  596. Task_WorkTaskReceipt data = new Task_WorkTaskReceipt
  597. {
  598. Content = dto.Content,
  599. CreateTime = DateTime.Now,
  600. CreateUserId = dto.UserId,
  601. IsApproved = 0,
  602. IsCompleted = dto.IsCompleted,
  603. WorkTaskId = dto.WorkTaskId,
  604. WorkOrderId = dto.WorkOrderId,
  605. FilePath = JsonConvert.SerializeObject(filePathArr)
  606. };
  607. var count = _sqlsugar.Insertable(data).ExecuteCommand();
  608. if (count > 0)
  609. {
  610. _ = AppNoticeLibrary.SendUserMsg_TaskSubMit_ToUser(task.Id,
  611. new List<string>() { task.CreateUserId.toString() });
  612. }
  613. jw.Code = 200;
  614. jw.Msg = $"{count}条回执单、{dto.Files}个文件保存成功!";
  615. return Ok(jw);
  616. }
  617. /// <summary>
  618. /// 无记录通过
  619. /// </summary>
  620. /// <param name="dto"></param>
  621. /// <returns></returns>
  622. [HttpPost]
  623. public async Task<IActionResult> SubmitWorkTaskNotRecord(SubmitWorkTaskNotRecord dto)
  624. {
  625. var jw = JsonView(false);
  626. jw.Data = "";
  627. var orderInfo = _sqlsugar.Queryable<Task_WorkOrder>().First(x => x.Id == dto.WorkOrderId && x.IsDel == 0);
  628. if (orderInfo == null)
  629. {
  630. jw.Msg = "参数有误!";
  631. return Ok(jw);
  632. }
  633. var task = _sqlsugar.Queryable<Task_WorkTask>().
  634. First(x => x.Id == dto.WorkTaskId && x.IsDel == 0);
  635. if (task == null)
  636. {
  637. jw.Msg = "任务不存在或已删除!";
  638. return Ok(jw);
  639. }
  640. //设置工单回执
  641. Task_WorkTaskReceipt data = new Task_WorkTaskReceipt
  642. {
  643. Content = string.Empty,
  644. CreateTime = DateTime.Now,
  645. CreateUserId = dto.UserId,
  646. IsApproved = 1,
  647. IsCompleted = 1,
  648. WorkTaskId = dto.WorkTaskId,
  649. WorkOrderId = dto.WorkOrderId,
  650. FilePath = string.Empty
  651. };
  652. _sqlsugar.BeginTran();
  653. try
  654. {
  655. var ReceiptId = _sqlsugar.Insertable(data)
  656. .ExecuteReturnIdentity();
  657. var existsApproved = _sqlsugar.Queryable<Task_WorkTaskReceipt>()
  658. .First(x => x.WorkOrderId == dto.WorkOrderId
  659. && x.WorkTaskId == dto.WorkTaskId
  660. && x.IsDel == 0
  661. && x.IsApproved == 1
  662. && x.Id != ReceiptId);
  663. if (ReceiptId > 0 && existsApproved == null && !task.IsExtraTask)
  664. {
  665. _sqlsugar.Updateable<Task_WorkOrder>()
  666. .SetColumns(x => new Task_WorkOrder
  667. {
  668. ProgressId = x.ProgressId + 1
  669. })
  670. .Where(x => x.Id == orderInfo.Id)
  671. .ExecuteCommand();
  672. }
  673. _sqlsugar.CommitTran();
  674. jw.Code = 200;
  675. jw.Msg = "SUCCESS!";
  676. jw.Data = ReceiptId;
  677. }
  678. catch (Exception ex)
  679. {
  680. _sqlsugar.RollbackTran();
  681. jw.Code = 500;
  682. jw.Msg = ex.Message;
  683. }
  684. return Ok(jw);
  685. }
  686. /// <summary>
  687. /// 软删除工作订单
  688. /// </summary>
  689. /// <param name="dto">删除参数</param>
  690. /// <returns></returns>
  691. [HttpPost]
  692. public async Task<IActionResult> SoftDeleteWorkOrder(SoftDeleteWorkOrderDto dto)
  693. {
  694. var jw = JsonView(false);
  695. if (dto.WorkOrderId < 1 || dto.UserId < 1)
  696. {
  697. jw.Msg = "参数有误!";
  698. return Ok(jw);
  699. }
  700. // 检查工作订单是否存在且未被删除
  701. var workOrder = _sqlsugar.Queryable<Task_WorkOrder>()
  702. .First(x => x.Id == dto.WorkOrderId && x.IsDel == 0);
  703. if (workOrder == null)
  704. {
  705. jw.Msg = "工作订单不存在或已被删除!";
  706. return Ok(jw);
  707. }
  708. // 检查权限:只有创建者或管理员可以删除
  709. if (workOrder.CreateUserId != dto.UserId)
  710. {
  711. jw.Msg = "权限不足,无法删除此工作订单!";
  712. return Ok(jw);
  713. }
  714. _sqlsugar.BeginTran();
  715. try
  716. {
  717. // 软删除工作订单
  718. var updateWorkOrderResult = _sqlsugar.Updateable<Task_WorkOrder>()
  719. .SetColumns(x => new Task_WorkOrder
  720. {
  721. IsDel = 1,
  722. DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  723. DeleteUserId = dto.UserId
  724. })
  725. .Where(x => x.Id == dto.WorkOrderId)
  726. .ExecuteCommand();
  727. // 软删除相关的工作任务
  728. var updateWorkTaskResult = _sqlsugar.Updateable<Task_WorkTask>()
  729. .SetColumns(x => new Task_WorkTask
  730. {
  731. IsDel = 1,
  732. DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  733. DeleteUserId = dto.UserId
  734. })
  735. .Where(x => x.WorkOrderId == dto.WorkOrderId)
  736. .ExecuteCommand();
  737. // 软删除相关的回执单
  738. var updateReceiptResult = _sqlsugar.Updateable<Task_WorkTaskReceipt>()
  739. .SetColumns(x => new Task_WorkTaskReceipt
  740. {
  741. IsDel = 1,
  742. DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  743. DeleteUserId = dto.UserId
  744. })
  745. .Where(x => x.WorkOrderId == dto.WorkOrderId)
  746. .ExecuteCommand();
  747. _sqlsugar.CommitTran();
  748. jw.Code = 200;
  749. jw.Msg = "工作订单删除成功!";
  750. jw.Data = new
  751. {
  752. WorkOrderId = dto.WorkOrderId,
  753. DeletedWorkTasks = updateWorkTaskResult,
  754. DeletedReceipts = updateReceiptResult,
  755. DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  756. };
  757. }
  758. catch (Exception ex)
  759. {
  760. _sqlsugar.RollbackTran();
  761. jw.Code = 500;
  762. jw.Msg = $"删除失败:{ex.Message}";
  763. }
  764. return Ok(jw);
  765. }
  766. /// <summary>
  767. /// 回执审核
  768. /// </summary>
  769. /// <param name="dto"></param>
  770. /// <returns></returns>
  771. [HttpPost]
  772. public async Task<IActionResult> AuditWorkTaskReceipt(AuditWorkTaskReceiptDto dto)
  773. {
  774. var jw = JsonView(false);
  775. if (dto.ReceiptId < 1 || dto.ApproverId < 1)
  776. {
  777. jw.Msg = "参数有误!";
  778. return Ok(jw);
  779. }
  780. if (dto.Approve == -1 && string.IsNullOrWhiteSpace(dto.RejectReason))
  781. {
  782. jw.Msg = "驳回必须填写原因!";
  783. return Ok(jw);
  784. }
  785. var receipt = _sqlsugar.Queryable<Task_WorkTaskReceipt>()
  786. .Includes<Task_WorkTask>(o => o.WorkTask)
  787. .First(x => x.Id == dto.ReceiptId && x.IsDel == 0);
  788. if (receipt == null)
  789. {
  790. jw.Msg = "回执单不存在或已删除!";
  791. return Ok(jw);
  792. }
  793. try
  794. {
  795. _sqlsugar.BeginTran();
  796. var existsApproved = _sqlsugar.Queryable<Task_WorkTaskReceipt>()
  797. .First(x => x.WorkOrderId == receipt.WorkOrderId && x.WorkTaskId == receipt.WorkTaskId && x.IsDel == 0 && x.IsApproved == 1);
  798. var affected = _sqlsugar.Updateable<Task_WorkTaskReceipt>()
  799. .SetColumns(x => new Task_WorkTaskReceipt
  800. {
  801. IsApproved = dto.Approve,
  802. RejectReason = dto.Approve == -1 ? dto.RejectReason : ""
  803. })
  804. .Where(x => x.Id == dto.ReceiptId)
  805. .ExecuteCommand();
  806. if (existsApproved == null && dto.Approve == 1 && !receipt.WorkTask.IsExtraTask)
  807. {
  808. _sqlsugar.Updateable<Task_WorkOrder>()
  809. .SetColumns(x => new Task_WorkOrder
  810. {
  811. ProgressId = x.ProgressId + 1
  812. })
  813. .Where(x => x.Id == receipt.WorkOrderId)
  814. .ExecuteCommand();
  815. }
  816. _sqlsugar.CommitTran();
  817. //企微通知
  818. _ = AppNoticeLibrary.SendUserMsg_TaskAudit_ToUser
  819. (receipt.WorkTaskId, dto.Approve == 1,
  820. dto.RejectReason,
  821. new List<string>() { receipt.WorkTask.AssignedUserId.toString() });
  822. jw.Code = 200;
  823. jw.Msg = "审核完成!";
  824. jw.Data = new
  825. {
  826. dto.ReceiptId,
  827. Status = dto.Approve == 1 ? "审核通过" : "审核驳回",
  828. dto.RejectReason,
  829. receipt.WorkOrderId,
  830. Affected = affected
  831. };
  832. }
  833. catch (Exception ex)
  834. {
  835. _sqlsugar.RollbackTran();
  836. jw.Code = 500;
  837. jw.Msg = $"审核失败:{ex.Message}";
  838. }
  839. return Ok(jw);
  840. }
  841. }
  842. }