存储过程未生成 → 兜底 C# 自动生成

快乐的昕的电脑

2025-11-18 62922f98de63b19f54c12a6ad8b39d61b62011ed

 Services/MesOrderStaManager.cs

@@ -130,6 +130,31 @@
                        "BEGIN AUTOMATIC_IPQC_FIRST_CHECK(:BILL_NO); END;",
                        new SugarParameter("BILL_NO", womdaa.Daa001, System.Data.DbType.String));
                }

                // 再次查询新生成的首检单
                var newLatest = Db.Queryable<MesQaItemsDetect02>()
                    .Where(s => s.Aufnr == womdaa.Daa001
                                && s.Ftype == "首检"
                                && (s.Fcancel == null || s.Fcancel != "Y"))
                    .OrderBy(s => s.CreateDate, OrderByType.Desc)
                    .First();

                // 存储过程未生成 → 兜底 C# 自动生成
                if (newLatest == null)
                {
                    Console.WriteLine("[重送检] 存储过程未生成，执行 C# 兜底逻辑");
                    var fallback = mesQaItemsDetect02Manager.AutomaticIpqcFirstCheck(womdaa.Daa001);
                    if (fallback)
                    {
                        newLatest = Db.Queryable<MesQaItemsDetect02>()
                            .Where(s => s.Aufnr == womdaa.Daa001
                                        && s.Ftype == "首检"
                                        && (s.Fcancel == null || s.Fcancel != "Y"))
                            .OrderBy(s => s.CreateDate, OrderByType.Desc)
                            .First();
                    }
                }

            }

            // 统一更新最新首检备注
@@ -150,11 +175,12 @@
        // ================== 不合格后重新送检（Flag == 2）==================
        else if (entity.Flag == 2)
        {
            // 第一单首检为不合格后，回传 Flag=2 时应“直接”生成一张新的首检单
            // 幂等策略：若最新首检已合格则不生成；若尚无首检或最新为不合格则立即生成新的
            Db.Ado.ExecuteCommand("SELECT ID FROM WOMDAA WHERE DAA001 = :BILL_NO FOR UPDATE",
            // 1.加锁防并发（行级锁）
            Db.Ado.ExecuteCommand(
                "SELECT ID FROM WOMDAA WHERE DAA001 = :BILL_NO FOR UPDATE",
                new SugarParameter("BILL_NO", womdaa.Daa001));

            // 2. 当前最新未作废首检单
            var latestFirst = Db.Queryable<MesQaItemsDetect02>()
                .Where(s => s.Aufnr == womdaa.Daa001
                            && s.Ftype == "首检"
@@ -162,31 +188,115 @@
                .OrderBy(s => s.CreateDate, OrderByType.Desc)
                .First();

            // 最新无记录 或 最新不合格 -> 生成新首检单
            if (latestFirst == null || latestFirst.FcheckResu == "不合格")
            bool needReCreate = false;
            /*
             3. 判断是否需要重新生成首检单
•   如果最新首检单存在且结果为“不合格”或“NG”，则需要重建首检单。
•   如果没有活动首检单，但存在已作废的不合格首检记录，也允许重建。
             */
            if (latestFirst != null)
            {
                Db.Ado.ExecuteCommand(
                    "BEGIN AUTOMATIC_IPQC_FIRST_CHECK(:BILL_NO); END;",
                    new SugarParameter("BILL_NO", womdaa.Daa001, System.Data.DbType.String));
                var resu = latestFirst.FcheckResu?.Trim();
                if (!string.IsNullOrEmpty(resu) &&
                    (resu == "不合格" || resu.Equals("NG", StringComparison.OrdinalIgnoreCase)))
                {
                    needReCreate = true;
                }
            }
            else
            {
                // 4. 没有活动首检单，判断是否存在已作废的不合格首检记录
                var existsCanceledNg = Db.Queryable<MesQaItemsDetect02>()
                    .Where(s => s.Aufnr == womdaa.Daa001
                                && s.Ftype == "首检"
                                && s.Fcancel == "Y"
                                && (s.FcheckResu == "不合格" || s.FcheckResu == "NG"))
                    .Any();
                if (existsCanceledNg)
                {
                    needReCreate = true;
                    Console.WriteLine("[重送检] 无活动首检单但存在作废的不合格记录，允许重建");
                }
            }

                // 获取刚生成的新首检单并写备注
            if (needReCreate)
            {
                // 作废当前活动不合格单
                if (latestFirst != null)
                {
                    Db.Updateable<MesQaItemsDetect02>()
                        .SetColumns(s => s.Fcancel == "Y")
                        .Where(s => s.Id == latestFirst.Id
                                    && (s.Fcancel == null || s.Fcancel != "Y"))
                        .ExecuteCommand();
                }

                bool procOk = true;
                string procErr = "";
                try
                {
                    // 5. 调用存储过程生成新首检单
                    Db.Ado.ExecuteCommand(
                        "BEGIN AUTOMATIC_IPQC_FIRST_CHECK(:BILL_NO); END;",
                        new SugarParameter("BILL_NO", womdaa.Daa001, System.Data.DbType.String));
                }
                catch (Exception ex)
                {
                    procOk = false;
                    procErr = ex.Message;
                    Console.WriteLine($"[重送检] 存储过程异常: {procErr}");
                }

                // 再次查询新生成的首检单
                var newLatest = 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 (newLatest != null)

                // 存储过程未生成 → 兜底 C# 自动生成
                if (newLatest == null)
                {
                    var ts = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
                    Console.WriteLine("[重送检] 存储过程未生成，执行 C# 兜底逻辑");
                    var fallback = mesQaItemsDetect02Manager.AutomaticIpqcFirstCheck(womdaa.Daa001);
                    if (fallback)
                    {
                        newLatest = Db.Queryable<MesQaItemsDetect02>()
                            .Where(s => s.Aufnr == womdaa.Daa001
                                        && s.Ftype == "首检"
                                        && (s.Fcancel == null || s.Fcancel != "Y"))
                            .OrderBy(s => s.CreateDate, OrderByType.Desc)
                            .First();
                    }
                }

                //6. 新首检单生成后，写入备注

                var ts = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
                //只有开工状态下可以暂停工单
                //当首检结果为‘合格’、‘不合格’时，更新备注
                if (newLatest != null && newLatest.FcheckResu == "合格")
                {
                    var remark = $"工控机于{ts}取消暂停重新送检生成的首检单";
                    Db.Updateable<MesQaItemsDetect02>()
                        .SetColumns(s => s.Remeke == remark)
                        .Where(s => s.Id == newLatest.Id)
                        .ExecuteCommand();
                }
                else if (newLatest != null && newLatest.FcheckResu == "不合格")
                {
                    var remark = $"工控机于{ts}不合格重新送检生成的首检单";
                    Db.Updateable<MesQaItemsDetect02>()
                        .SetColumns(s => s.Remeke == remark)
                        .Where(s => s.Id == newLatest.Id)
                        .ExecuteCommand();
                }
                else
                {
                    Console.WriteLine("[重送检] 仍未生成新首检单，请检查存储过程计数是否排除作废单。");
                }
            }
            // 若最新已合格则不生成新单，直接继续后续流程（不覆盖其备注）
        }

        // ========= 首检不合格清空送检时间处理（Flag != 2 时才清空；并生成统一 remark） =========