快乐的昕的电脑
2025-10-22 330481e48b742be6c465b543035c2424dd9b311d
Services/MesOrderStaManager.cs
@@ -92,11 +92,13 @@
    /// <summary>
    ///     更新机器时间并处理首检
    ///     变更说明(新逻辑):
    ///     1) 首检结果“不合格”时不立即重建,不清空送检时间,只提示需要再次送检
    ///     2) 当用户再次点击“送检呼叫”产生新的送检时间(与数据库原值不同)且上一张首检结果“不合格”,才重建首检单
    ///     3) 不存在首检单时仍直接创建
    ///     4) 首检合格且送检时间 >= 调机开始时间时:写入调机完成时间与开工时间
    ///     逻辑说明:
    ///     1) 首检结果“不合格”不立即重建,等待用户再次点击送检呼叫(送检时间变化)触发重建
    ///     2) 首次无首检单或“不合格”且送检时间变化 => 调用存储过程重建首检单
    ///     3) 重建后保留当前送检时间,不清空
    ///     4) 不合格但送检时间未变化 => 提示用户需要重新送检
    ///     5) 合格且送检时间 >= 调机开始时间 => 写入开工与调机完成时间
    ///     可选扩展:支持 ForceRebuild 强制重建(如果前端加字段)
    /// </summary>
    public bool ChangeMachineTime(MesOrderSta entity)
    {
@@ -107,10 +109,9 @@
        var womdaa = Db.Queryable<Womdaa>().Where(s => s.Id == entity.OrderId).First();
        if (womdaa == null) throw new Exception("工单不存在");
        // 读取现有状态(用于比较送检时间是否变化)
        var dbSta = Db.Queryable<MesOrderSta>().Where(s => s.Id == entity.Id).First();
        // 行级锁:避免并发重建
        // 行级锁
        Db.Ado.ExecuteCommand("SELECT ID FROM WOMDAA WHERE DAA001 = :BILL_NO FOR UPDATE",
            new SugarParameter("BILL_NO", womdaa.Daa001));
@@ -119,29 +120,37 @@
            .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;
        // ForceRebuild 可选扩展
        var forceRebuild = (entity as dynamic)?.ForceRebuild == true;
        // 判定是否需要重建:
        // 1) 首次(latestFirst == null)
        // 2) 上一张是“不合格” 且 用户本次送检时间已发生变化(表示二次送检)
        var needRebuild = latestFirst == null ||
                          (string.Equals(latestResult, FirstCheckResultNG, StringComparison.OrdinalIgnoreCase) && isShoutTimeChanged);
        // 立即重建条件:首次无单 或 最新结果 == 不合格 或 强制
        var needRebuild = latestFirst == null
                          || string.Equals(latestResult, FirstCheckResultNG, StringComparison.OrdinalIgnoreCase)
                          || forceRebuild;
        if (needRebuild)
        {
            var previousState = latestResult == null ? "首次创建" :
                (latestResult == FirstCheckResultNG ? "不合格后重建" : "重建");
            var previousState = latestResult == null ? "首次创建"
                : (latestResult == FirstCheckResultNG ? "不合格后立即重建" : "重建");
            // 可选:保留旧记录,或标记旧记录作废(如果需要避免多条待检)
            // 若要作废上一条不合格单:取消即可
            if (latestFirst != null && string.Equals(latestResult, FirstCheckResultNG, StringComparison.OrdinalIgnoreCase))
            {
                Db.Updateable<MesQaItemsDetect02>()
                  .SetColumns(s => s.Fcancel == "Y")
                  .Where(s => s.Id == latestFirst.Id)
                  .ExecuteCommand();
            }
            // 调用存储过程创建新首检单
            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 == FirstCheckType && (s.Fcancel == null || s.Fcancel != "Y"))
                .OrderBy(s => s.CreateDate, OrderByType.Desc)
@@ -151,29 +160,24 @@
            {
                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();
                  .SetColumns(s => s.Remeke == $"工控机于{ts}自动创建的首检单({previousState})")
                  .Where(s => s.Id == latestFirst.Id)
                  .ExecuteCommand();
            }
            // 重建后不清空本次送检时间(保留用户新输入)
            entity.remark = previousState.Contains("不合格") ? "不合格已重建,等待检验" : entity.remark;
            if (previousState.Contains("不合格"))
                entity.remark = "不合格已重建,等待检验";
        }
        else
        {
            // 不需要重建但上一张不合格且送检时间未变化 => 提示需要重新送检
            if (latestFirst != null && string.Equals(latestResult, FirstCheckResultNG, StringComparison.OrdinalIgnoreCase) && !isShoutTimeChanged)
            // 不需要重建时仅写结果备注(若已有首检)
            if (latestFirst != null && !string.IsNullOrEmpty(latestResult))
            {
                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();
                  .SetColumns(s => s.Remeke == $"工控机于{ts}首检结果:{latestResult}")
                  .Where(s => s.Id == latestFirst.Id)
                  .ExecuteCommand();
            }
        }
@@ -191,10 +195,8 @@
            var content = new StringContent(
                JsonConvert.SerializeObject(new { machineNo = entity.MachineNo }),
                Encoding.UTF8, "application/json");
            var response = httpClient.PostAsync("http://192.168.0.94:9095/Numerical/RefreshDevBycl", content)
                .GetAwaiter().GetResult();
            if (response.IsSuccessStatusCode)
            {
                var responseString = response.Content.ReadAsStringAsync().GetAwaiter().GetResult();
@@ -227,7 +229,7 @@
        };
        Db.Insertable<MesAnchors>(eAnchors).ExecuteCommand();
        // 合格且送检时间有效 => 写调机完成时间与开工时间
        // 合格写开工/调机完成
        if (!string.IsNullOrEmpty(entity.MaShoutTime)
            && DateTime.TryParse(entity.MaShoutTime, out var sjTime)
            && DateTime.TryParse(entity.MaStartTime, out var startTime)
@@ -245,7 +247,6 @@
            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)
@@ -256,6 +257,7 @@
            .ExecuteCommand() > 0;
    }
    /// <summary>
    ///     初始化工单状态
    /// </summary>