TaskController.cs 30 KB

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