TaskController.cs 30 KB

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