班前会更新历史超时数据

APT.MicroApi/APT.PP.WebApi/Controllers/Api/FOController.cs

@@ -2290,5 +2290,53 @@ namespace APT.PP.WebApi.Controllers.Api.PP
                 return true;
             });
         }
+
+        /// <summary>
+        /// 更新班前会议超时字段
+        /// </summary>
+        /// <param name="pageFilter"></param>
+        /// <returns></returns>
+        [HttpPost, Route("PremeetingSync")]
+        public JsonActionResult<bool> PremeetingSync([FromBody] KeywordFilter filter)
+        {
+            return SafeExecute<bool>(() =>
+            {
+                try
+                {
+                    var preClass = this.GetEntities<T_FO_PRE_SHIFT_MEETING_RECORD>(t => t.PRE_MEETING_STATUS == FOPreMeetingStatusEnum.归档 && t.OVERTIME == FOISOVERTIME.未统计, filter);
+                    var preClassIds = preClass.Select(t => t.ID).ToList();
+                    var tasks = this.GetEntities<T_FM_NOTIFICATION_TASK>(t => t.SOURCE_DATA_ID!=null &&  preClassIds.Contains((Guid)t.SOURCE_DATA_ID), filter);
+                    if (preClass != null && preClass.Any())
+                    {
+                        foreach (var item in preClass)
+                        {
+                            var taskOver = tasks.FirstOrDefault(t => t.SOURCE_DATA_ID == item.ID && t.NOTICE_STATUS == 2);
+                            if (taskOver != null)
+                            {
+                                item.OVERTIME = FOISOVERTIME.超时;
+                            }
+                            else
+                            {
+                                item.OVERTIME = FOISOVERTIME.未超时;
+                            }
+                        }
+                    }
+                    UnifiedCommit(() =>
+                    {
+                        if (preClass != null && preClass.Any())
+                            BantchSaveEntityNoCommit(preClass);
+                    });
+                }
+                catch (Exception ex)
+                {
+                    if (!string.IsNullOrEmpty(ex.StackTrace))
+                        throw new Exception("错误日志：[StackTrace]" + ex.StackTrace);
+                    else
+                        throw new Exception("【" + HttpContext.Request.Path + "】错误日志：[Message]" + ex.Message);
+                }
+
+                return true;
+            });
+        }
     }
 }