逻辑优化

快乐的昕的电脑

2025-10-22 c60af0293161db2349a67f6279fb71ec0e165aa6

 Services/MesOrderStaManager.cs

@@ -92,83 +92,92 @@

    /// <summary>
    ///     更新机器时间并处理首检
    ///     变更说明：
    ///     1) 最新首检结果为“不合格”时：只清空 MA_SHOUT_TIME（送检呼叫时间），不重建首检单
    ///     2) 若不存在首检单或最新首检结果为“不合格”时：允许继续创建（重建）首检单
    ///     3) 首检合格且送检时间 >= 调机开始时间时：写入调机完成时间与开工时间（沿用原逻辑）
    ///     变更说明（新逻辑）：
    ///     1) 首检结果“不合格”时不立即重建，不清空送检时间，只提示需要再次送检
    ///     2) 当用户再次点击“送检呼叫”产生新的送检时间（与数据库原值不同）且上一张首检结果“不合格”，才重建首检单
    ///     3) 不存在首检单时仍直接创建
    ///     4) 首检合格且送检时间 >= 调机开始时间时：写入调机完成时间与开工时间
    /// </summary>
    public bool ChangeMachineTime(MesOrderSta entity)
    {
        var womdaa = Db.Queryable<Womdaa>()
            .Where(s => s.Id == entity.OrderId).First();
        const string FirstCheckType = "首检";
        const string FirstCheckResultOK = "合格";
        const string FirstCheckResultNG = "不合格";

        var womdaa = Db.Queryable<Womdaa>().Where(s => s.Id == entity.OrderId).First();
        if (womdaa == null) throw new Exception("工单不存在");

        MesQaItemsDetect02 latestFirst = null;
        // 读取现有状态（用于比较送检时间是否变化）
        var dbSta = Db.Queryable<MesOrderSta>().Where(s => s.Id == entity.Id).First();

        if (entity.Flag == 1)
        // 行级锁：避免并发重建
        Db.Ado.ExecuteCommand("SELECT ID FROM WOMDAA WHERE DAA001 = :BILL_NO FOR UPDATE",
            new SugarParameter("BILL_NO", womdaa.Daa001));

        // 最新首检
        var latestFirst = Db.Queryable<MesQaItemsDetect02>()
            .Where(s => s.Aufnr == womdaa.Daa001 && s.Ftype == FirstCheckType && (s.Fcancel == null || s.Fcancel != "Y"))
            .OrderBy(s => s.CreateDate, OrderByType.Desc)
            .First();

        var latestResult = latestFirst?.FcheckResu?.Trim();

        // 送检时间是否发生变化（前端重新点击送检）
        var isShoutTimeChanged = !string.IsNullOrEmpty(entity.MaShoutTime)
                                 && entity.MaShoutTime != dbSta?.MaShoutTime;

        // 判定是否需要重建：
        // 1) 首次（latestFirst == null）
        // 2) 上一张是“不合格” 且 用户本次送检时间已发生变化（表示二次送检）
        var needRebuild = latestFirst == null ||
                          (string.Equals(latestResult, FirstCheckResultNG, StringComparison.OrdinalIgnoreCase) && isShoutTimeChanged);

        if (needRebuild)
        {
            // 行级锁防并发
            Db.Ado.ExecuteCommand("SELECT ID FROM WOMDAA WHERE DAA001 = :BILL_NO FOR UPDATE",
                new SugarParameter("BILL_NO", womdaa.Daa001));
            var previousState = latestResult == null ? "首次创建" :
                (latestResult == FirstCheckResultNG ? "不合格后重建" : "重建");

            // 当前最新首检
            Db.Ado.ExecuteCommand(
                "BEGIN AUTOMATIC_IPQC_FIRST_CHECK(:BILL_NO); END;",
                new SugarParameter("BILL_NO", womdaa.Daa001, System.Data.DbType.String));

            // 重取
            latestFirst = Db.Queryable<MesQaItemsDetect02>()
                .Where(s => s.Aufnr == womdaa.Daa001 && s.Ftype == "首检" && (s.Fcancel == null || s.Fcancel != "Y"))
                .Where(s => s.Aufnr == womdaa.Daa001 && s.Ftype == FirstCheckType && (s.Fcancel == null || s.Fcancel != "Y"))
                .OrderBy(s => s.CreateDate, OrderByType.Desc)
                .First();

            // 不存在 或 最新结果为“不合格” => 允许创建首检单（新增逻辑，保留注释）
            var needCreate = latestFirst == null || latestFirst.FcheckResu == "不合格";

            if (needCreate)
            if (latestFirst != null)
            {
                // 不存在 或 “不合格” => 重新创建首检单
                Db.Ado.ExecuteCommand(
                    "BEGIN AUTOMATIC_IPQC_FIRST_CHECK(:BILL_NO); END;",
                    new SugarParameter("BILL_NO", womdaa.Daa001, System.Data.DbType.String));

                // 重新获取最新首检单
                latestFirst = Db.Queryable<MesQaItemsDetect02>()
                    .Where(s => s.Aufnr == womdaa.Daa001 && s.Ftype == "首检" && (s.Fcancel == null || s.Fcancel != "Y"))
                    .OrderBy(s => s.CreateDate, OrderByType.Desc)
                    .First();

                if (latestFirst != null)
                {
                    var ts = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
                    var trigger = latestFirst.FcheckResu == "不合格" ? "不合格重建" : "首次创建";
                    Db.Updateable<MesQaItemsDetect02>()
                        .SetColumns(s => s.Remeke == $"工控机于{ts}自动创建的首检单({trigger})")
                        .Where(s => s.Id == latestFirst.Id)
                        .ExecuteCommand();
                }
                var ts = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
                Db.Updateable<MesQaItemsDetect02>()
                    .SetColumns(s => s.Remeke == $"工控机于{ts}自动创建的首检单({previousState})")
                    .Where(s => s.Id == latestFirst.Id)
                    .ExecuteCommand();
            }
            else
            {
                // 最新结果为“不合格” => 仅清空送检时间，不重建
                if (latestFirst != null && latestFirst.FcheckResu == "不合格")
                {
                    Db.Updateable<MesOrderSta>()
                        .SetColumns(s => s.MaShoutTime == null)
                        .Where(s => s.Id == entity.Id)
                        .ExecuteCommand();

                    entity.MaShoutTime = null;
                    entity.remark = $"最新首检结果“不合格”，已清空送检时间，待再次送检";
                }
                else if (latestFirst != null)
                {
                    // 其它结果仅更新备注
                    var ts = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
                    Db.Updateable<MesQaItemsDetect02>()
                        .SetColumns(s => s.Remeke == $"工控机于{ts}首检结果：{latestFirst.FcheckResu}")
                        .Where(s => s.Id == latestFirst.Id)
                        .ExecuteCommand();
                }
            // 重建后不清空本次送检时间（保留用户新输入）
            entity.remark = previousState.Contains("不合格") ? "不合格已重建，等待检验" : entity.remark;
        }
        else
        {
            // 不需要重建但上一张不合格且送检时间未变化 => 提示需要重新送检
            if (latestFirst != null && string.Equals(latestResult, FirstCheckResultNG, StringComparison.OrdinalIgnoreCase) && !isShoutTimeChanged)
            {
                entity.remark = "上一首检不合格，请重新点击送检呼叫以生成新的首检单";
            }
            else if (latestFirst != null)
            {
                // 其它情况更新备注为当前结果
                var ts = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
                Db.Updateable<MesQaItemsDetect02>()
                    .SetColumns(s => s.Remeke == $"工控机于{ts}首检结果：{latestResult}")
                    .Where(s => s.Id == latestFirst.Id)
                    .ExecuteCommand();
            }
        }

        // 原报工/数采锚点逻辑保持
        // 报工锚点逻辑保持
        var mesReporting = Db.Queryable<MesReporting>()
            .Where(s => s.BillNo == womdaa.Daa001)
            .OrderByDescending(s => s.Id)
@@ -201,7 +210,6 @@
        }
        catch (Exception ex)
        {
            // 记录异常但不阻止流程（保留原注释）
            Console.WriteLine($"发送数据刷新请求时出错: {ex.Message}");
        }

@@ -219,34 +227,25 @@
        };
        Db.Insertable<MesAnchors>(eAnchors).ExecuteCommand();

        // 若送检时间存在且最新首检合格 => 写调机完成与开工时间
        if (!string.IsNullOrEmpty(entity.MaShoutTime))
        // 合格且送检时间有效 => 写调机完成时间与开工时间
        if (!string.IsNullOrEmpty(entity.MaShoutTime)
            && DateTime.TryParse(entity.MaShoutTime, out var sjTime)
            && DateTime.TryParse(entity.MaStartTime, out var startTime)
            && sjTime >= startTime
            && latestFirst != null
            && string.Equals(latestFirst.FcheckResu?.Trim(), FirstCheckResultOK, StringComparison.OrdinalIgnoreCase))
        {
            if (DateTime.TryParse(entity.MaShoutTime, out var sjTime) &&
                DateTime.TryParse(entity.MaStartTime, out var startTime) &&
                sjTime >= startTime)
            QualifiedInspection(new OrderMachineDto
            {
                var sjRecord = latestFirst ??
                               Db.Queryable<MesQaItemsDetect02>()
                                   .Where(x => x.Aufnr == womdaa.Daa001 && x.Ftype == "首检" && (x.Fcancel == null || x.Fcancel != "Y"))
                                   .OrderBy(x => x.CreateDate, OrderByType.Desc)
                                   .First();

                if (sjRecord != null && sjRecord.FcheckResu == "合格")
                {
                    QualifiedInspection(new OrderMachineDto
                    {
                        OrderId = entity.OrderId,
                        orderNo = entity.OrderNo,
                        machineNo = entity.MachineNo
                    });
                    entity.StartTime = entity.MaShoutTime;
                    entity.MaEndTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
                }
            }
                OrderId = entity.OrderId,
                orderNo = entity.OrderNo,
                machineNo = entity.MachineNo
            });
            entity.StartTime = entity.MaShoutTime;
            entity.MaEndTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
        }

        // 更新工单状态表（保留原注释）
        // 更新
        return Db.Updateable<MesOrderSta>()
            .SetColumnsIF(entity.MaShoutTime != null, s => s.MaShoutTime == entity.MaShoutTime)
            .SetColumnsIF(entity.MaStartTime != null, s => s.MaStartTime == entity.MaStartTime)