From 82dac540156cb29e58c86f7d7d840e3c7e548c15 Mon Sep 17 00:00:00 2001
From: xwt <2740516069@qq.com>
Date: 星期四, 14 八月 2025 19:55:41 +0800
Subject: [PATCH] 来料检,入库检,首检巡检。

---
 StandardInterface/MES.Service/Dto/service/RKJDaa001.cs           |    5 
 StandardInterface/MES.Service/Modes/QsItemOqcReq.cs              |   26 ++
 StandardInterface/MES.Service/service/QC/LljService.cs           |   12 +
 StandardInterface/MES.Service/Modes/Womdaa.cs                    |    6 
 StandardInterface/MES.Service/service/QC/RKJService.cs           |  337 +++++++++++++++++++++++++++------
 StandardInterface/MESApplication/Controllers/QC/RKJController.cs |  152 +++++++++++++++
 StandardInterface/MES.Service/Modes/LtsLlj.cs                    |    6 
 StandardInterface/MES.Service/Dto/service/RKJDto.cs              |    3 
 StandardInterface/MESApplication/appsettings.json                |    2 
 9 files changed, 471 insertions(+), 78 deletions(-)

diff --git a/StandardInterface/MES.Service/Dto/service/RKJDaa001.cs b/StandardInterface/MES.Service/Dto/service/RKJDaa001.cs
index 679b819..e1e9d3b 100644
--- a/StandardInterface/MES.Service/Dto/service/RKJDaa001.cs
+++ b/StandardInterface/MES.Service/Dto/service/RKJDaa001.cs
@@ -12,7 +12,7 @@
     public decimal? ItemInId { get; set; }
     // 宸ュ崟鍙�
     [SugarColumn(ColumnName = "RBILL_NO")]
-    public string? RBillNo { get; set; }
+    public string? RbillNo { get; set; }
 
     // 鐗╂枡缂栫爜
     [SugarColumn(ColumnName = "ITEM_NO")] 
@@ -38,8 +38,5 @@
     [SugarColumn(ColumnName = "DAA020")]
     public string? Daa020 { get; set; }
 
-    //鐢宠鍗曞彿
-    [SugarColumn(ColumnName = "BILL_NO")]
-    public string? BillNo { get; set; }
 
 }
\ No newline at end of file
diff --git a/StandardInterface/MES.Service/Dto/service/RKJDto.cs b/StandardInterface/MES.Service/Dto/service/RKJDto.cs
index 822f798..56f1425 100644
--- a/StandardInterface/MES.Service/Dto/service/RKJDto.cs
+++ b/StandardInterface/MES.Service/Dto/service/RKJDto.cs
@@ -19,6 +19,9 @@
     public string? Remarks { get; set; }
     // 閫佹鎵规
     public string? RbillNo { get; set; }
+    
+    // 閫佹鏁伴噺
+    public decimal? quantity { get; set; }
 
     //==========================================
     //宸℃涓诲瓙琛ㄩ渶瑕佺殑鏁版嵁
diff --git a/StandardInterface/MES.Service/Modes/LtsLlj.cs b/StandardInterface/MES.Service/Modes/LtsLlj.cs
index 698ddb1..710ac3d 100644
--- a/StandardInterface/MES.Service/Modes/LtsLlj.cs
+++ b/StandardInterface/MES.Service/Modes/LtsLlj.cs
@@ -227,6 +227,12 @@
     [SugarColumn(ColumnName = "SSCJ")]
     public string? SSCJ { get; set; }
 
+    /// <summary>
+    ///     妫�楠岄」鐩暟閲忥紙闈炴暟鎹簱瀛楁锛岀敤浜庡墠绔樉绀猴級
+    /// </summary>
+    [SugarColumn(IsIgnore = true)]
+    public int? InspectionItemCount { get; set; }
+
 
 
 }
\ No newline at end of file
diff --git a/StandardInterface/MES.Service/Modes/QsItemOqcReq.cs b/StandardInterface/MES.Service/Modes/QsItemOqcReq.cs
index 50f6af0..7a4d22f 100644
--- a/StandardInterface/MES.Service/Modes/QsItemOqcReq.cs
+++ b/StandardInterface/MES.Service/Modes/QsItemOqcReq.cs
@@ -125,6 +125,24 @@
     [SugarColumn(ColumnName = "RBILL_NO")]
     public string? RbillNo { get; set; }
 
+    /// <summary>
+    ///     杞﹂棿
+    /// </summary>
+    [SugarColumn(ColumnName = "WORK_SHOP")]
+    public string? WorkShop { get; set; }
+
+    /// <summary>
+    ///     閮ㄩ棬ID
+    /// </summary>
+    [SugarColumn(ColumnName = "DEPARTMENT_ID")]
+    public string? DepartmentId { get; set; }
+
+    /// <summary>
+    ///     鐢熶骇绾跨紪鍙�
+    /// </summary>
+    [SugarColumn(ColumnName = "LINE_NO")]
+    public string? LineNo { get; set; }
+
     // 娣诲姞浠ヤ笅瀛楁浠ラ�傚簲鏌ヨ杩斿洖鐨勬暟鎹�
     [SugarColumn(IsIgnore = true)] public string? ItemName { get; set; }
 
@@ -138,7 +156,9 @@
 
     [SugarColumn(IsIgnore = true)] public string? Daa015 { get; set; }
 
-    [SugarColumn(IsIgnore = true)] public string? LineNo { get; set; }
-
-    [SugarColumn(IsIgnore = true)] public decimal? Quantity { get; set; }
+    /// <summary>
+    ///     閫佹鏁伴噺
+    /// </summary>
+    [SugarColumn(ColumnName = "QUANTITY")]
+    public decimal? Quantity { get; set; }
 }
\ No newline at end of file
diff --git a/StandardInterface/MES.Service/Modes/Womdaa.cs b/StandardInterface/MES.Service/Modes/Womdaa.cs
index 3cd62f8..c7f83af 100644
--- a/StandardInterface/MES.Service/Modes/Womdaa.cs
+++ b/StandardInterface/MES.Service/Modes/Womdaa.cs
@@ -195,10 +195,10 @@
     public string? Daa026 { get; set; }
 
     /// <summary>
-    ///     宸叉姤妫�锛�0-鏈姤妫�锛�1-宸叉姤妫�
+    ///     鐗╂枡ID锛堢敤浜庡叧鑱旀煡璇級
     /// </summary>
-    [SugarColumn(ColumnName = "IS_REPORTCHECK")]
-    public decimal? IsReportcheck { get; set; }
+    [SugarColumn(IsIgnore = true)]
+    public decimal? ItemId { get; set; }
 
     /// <summary>
     ///     鎶ユ浜�
diff --git a/StandardInterface/MES.Service/service/QC/LljService.cs b/StandardInterface/MES.Service/service/QC/LljService.cs
index 341a0a4..78ba1fb 100644
--- a/StandardInterface/MES.Service/service/QC/LljService.cs
+++ b/StandardInterface/MES.Service/service/QC/LljService.cs
@@ -70,6 +70,18 @@
             .OrderBy("CASE WHEN a.EMERGENCY = 1 THEN 0 ELSE 1 END, CASE WHEN a.STATUS = '宸叉彁浜�' THEN 0 ELSE 1 END, a.IQC_DATE desc, a.ID asc")
             .ToPageList(queryObj.PageIndex, queryObj.Limit, ref totalCount);
 
+        // 涓烘瘡涓楠屽崟娣诲姞妫�楠岄」鐩暟閲忎俊鎭�
+        foreach (var item in pageList)
+        {
+            // 鑾峰彇璇ユ楠屽崟鐨勬楠岄」鐩暟閲�
+            var itemCount = db.Queryable<MesQaItemsDetectDetail5>()
+                .Where(x => x.ReleaseNo == item.ReleaseNo)
+                .Count();
+            
+            // 璁剧疆妫�楠岄」鐩暟閲�
+            item.InspectionItemCount = itemCount;
+        }
+        
         var emergencyValues = pageList.Select(item => item.EMERGENCY).ToList(); 
         return (pageList, totalCount);
     }
diff --git a/StandardInterface/MES.Service/service/QC/RKJService.cs b/StandardInterface/MES.Service/service/QC/RKJService.cs
index f103adf..06e7a22 100644
--- a/StandardInterface/MES.Service/service/QC/RKJService.cs
+++ b/StandardInterface/MES.Service/service/QC/RKJService.cs
@@ -3,6 +3,8 @@
 using MES.Service.Modes;
 using MES.Service.util;
 using SqlSugar;
+using System.Linq;
+using System.Data;
 
 namespace MES.Service.service.QC;
 
@@ -16,22 +18,49 @@
     {
         var db = SqlSugarHelper.GetInstance();
         var date = DateTime.Now.ToString("yyyy-MM-dd");
-        var sql =
-            "select max(RELEASE_NO) from QS_ITEM_OQC_REQ where RELEASE_NO like 'RKJY%' and to_char(CREATE_DATE,'yyyy-mm-dd') ='" +
-            date + "'";
-
-        var maxBillNo = db.Ado.SqlQuerySingle<string>(sql);
-
-        var number = "0001";
-        if (maxBillNo != null)
+        
+        try
         {
-            maxBillNo = maxBillNo.Substring(12);
-            var no = Convert.ToInt32(maxBillNo);
-            no++;
-            number = no.ToString().PadLeft(4, '0');
-        }
+            // 鏌ヨ褰撳ぉ鎵�鏈変互RKJY寮�澶寸殑妫�楠屽崟鍙�
+            var sql = @"
+                SELECT RELEASE_NO 
+                FROM QS_ITEM_OQC_REQ 
+                WHERE RELEASE_NO LIKE 'RKJY%' 
+                AND TO_CHAR(CREATE_DATE,'yyyy-mm-dd') = @date
+                ORDER BY RELEASE_NO DESC";
 
-        return "RKJY" + date.Replace("-", "") + number;
+            var existingNumbers = db.Ado.SqlQuery<string>(sql, new { date });
+            
+            var number = "0001";
+            if (existingNumbers != null && existingNumbers.Count > 0)
+            {
+                // 鎵惧埌鏈�澶х殑缂栧彿
+                var maxNumber = existingNumbers
+                    .Where(x => x != null && x.Length >= 16) // 纭繚闀垮害瓒冲
+                    .Select(x => x.Substring(12, 4))
+                    .Where(x => int.TryParse(x, out _))
+                    .Select(x => int.Parse(x))
+                    .DefaultIfEmpty(0)
+                    .Max();
+                
+                number = (maxNumber + 1).ToString().PadLeft(4, '0');
+            }
+
+            var result = "RKJY" + date.Replace("-", "") + number;
+            
+            // 娣诲姞鏃ュ織璁板綍锛堝彲閫夛級
+            Console.WriteLine($"Generated RKJ number: {result}, Date: {date}, Existing count: {existingNumbers?.Count ?? 0}");
+            
+            return result;
+        }
+        catch (Exception ex)
+        {
+            // 濡傛灉鍑虹幇寮傚父锛屼娇鐢ㄦ椂闂存埑浣滀负澶囬�夋柟妗�
+            var timestamp = DateTime.Now.ToString("yyyyMMddHHmmss");
+            var fallbackNumber = "RKJY" + date.Replace("-", "") + timestamp.Substring(8, 4);
+            Console.WriteLine($"Error generating RKJ number, using fallback: {fallbackNumber}, Error: {ex.Message}");
+            return fallbackNumber;
+        }
     }
 
     //閫夋嫨浜х嚎
@@ -48,16 +77,84 @@
             .ToList();
     }
 
-
-    //鑾峰彇宸ュ崟鍙�
-    public List<RKJDaa001> GetDaa001s(string lineNo)
+    /// <summary>
+    /// 鑾峰彇鏈夌嚎浣撶殑閮ㄩ棬鍒楄〃锛堢敓浜ц溅闂达級
+    /// </summary>
+    /// <returns>閮ㄩ棬鍒楄〃</returns>
+    public List<dynamic> GetDepartmentsWithLines()
     {
         var db = SqlSugarHelper.GetInstance();
-        return db.Queryable<RKJDaa001>()
-            .Where(t => t.Daa015 == lineNo)
-            .OrderBy(t => t.BillNo, OrderByType.Desc)
+        var sql = @"
+            SELECT DISTINCT 
+                d.DEPARTMENTID as departmentid,
+                d.DEPARTMENTNAME as departmentname
+            FROM SYS_DEPARTMENT d
+            INNER JOIN MES_LINE l ON d.DEPARTMENTID = l.DEPOT_ID
+            WHERE L.LINE_NO IS NOT NULL
+            ORDER BY d.DEPARTMENTNAME";
+
+        return db.Ado.SqlQuery<dynamic>(sql);
+    }
+
+    /// <summary>
+    /// 鏍规嵁閮ㄩ棬ID鑾峰彇璇ラ儴闂ㄤ笅鐨勭嚎浣撳垪琛�
+    /// </summary>
+    /// <param name="departmentId">閮ㄩ棬ID</param>
+    /// <returns>绾夸綋鍒楄〃</returns>
+    public List<dynamic> GetLinesByDepartment(string departmentId)
+    {
+        var db = SqlSugarHelper.GetInstance();
+        var sql = @"
+            SELECT 
+                l.LINE_NO as lineNo,
+                l.LINE_NAME as lineName
+            FROM MES_LINE l
+            WHERE l.DEPOT_ID = @departmentId
+            ORDER BY l.LINE_NAME";
+
+        return db.Ado.SqlQuery<dynamic>(sql, new { departmentId });
+    }
+
+    /// <summary>
+    /// 淇濆瓨閮ㄩ棬閫夋嫨
+    /// </summary>
+    /// <param name="id">妫�楠屽崟ID</param>
+    /// <param name="departmentId">閮ㄩ棬ID</param>
+    /// <param name="departmentName">閮ㄩ棬鍚嶇О</param>
+    /// <returns>鎿嶄綔缁撴灉</returns>
+    public bool SaveDepartmentSelection(decimal id, string departmentId, string departmentName)
+    {
+        var db = SqlSugarHelper.GetInstance();
+        var sql = @"
+            UPDATE QS_ITEM_OQC_REQ 
+            SET WORK_SHOP = @departmentName, DEPARTMENT_ID = @departmentId
+            WHERE ID = @id";
+
+        return db.Ado.ExecuteCommand(sql, new { id, departmentId, departmentName }) > 0;
+    }
+
+
+    //鑾峰彇宸ュ崟鍙�
+    public List<Womdaa> GetDaa001s(string lineNo)
+    {
+        var db = SqlSugarHelper.GetInstance();
+        return db.Queryable<Womdaa, MesItems>((w, m) => new JoinQueryInfos(
+                JoinType.Left, w.Daa002 == m.Id.ToString()))
+            .Where((w, m) => w.Daa015 == lineNo)
+            .OrderBy((w, m) => w.Daa001, OrderByType.Desc)
+            .Select((w, m) => new Womdaa
+            {
+                Id = w.Id,
+                Daa001 = w.Daa001, // 宸ュ崟鍙�
+                Daa002 = m.ItemNo, // 浜у搧缂栫爜锛堜粠MesItems琛ㄨ幏鍙栵級
+                Daa003 = w.Daa003, // 浜у搧鍚嶇О
+                Daa004 = w.Daa004, // 浜у搧瑙勬牸
+                Daa008 = w.Daa008, // 宸ュ崟鏁伴噺
+                Daa015 = w.Daa015, // 鐢熶骇绾垮埆
+                // 娣诲姞鐗╂枡ID瀛楁
+                ItemId = m.Id // 鐗╂枡ID
+            })
             .ToList();
-        //return null;
     }
 
     //鏍规嵁妫�楠屾爣鍑嗘潵璁$畻妫�楠屼釜鏁�
@@ -228,9 +325,55 @@
 
             xj.CreateBy = userNo;
             xj.CreateDate = DateTime.Now;
+            
+            // 纭繚妫�楠屽崟鍙疯姝g‘璁剧疆
+            if (string.IsNullOrEmpty(xj.ReleaseNo))
+            {
+                xj.ReleaseNo = getMaxBillNo();
+            }
+            
+            // 纭繚鐢熶骇绾跨紪鍙疯姝g‘璁剧疆
+            if (string.IsNullOrEmpty(xj.LineNo) && !string.IsNullOrEmpty(xj.Daa015))
+            {
+                xj.LineNo = xj.Daa015;
+            }
+            
+            // 纭繚宸ュ崟鍙疯姝g‘璁剧疆
+            if (string.IsNullOrEmpty(xj.BillNo) && !string.IsNullOrEmpty(xj.RbillNo))
+            {
+                xj.BillNo = xj.RbillNo;
+            }
+            
+            // 纭繚鐗╂枡ID琚纭缃紙濡傛灉涓虹┖锛屽皾璇曚粠鐗╂枡缂栫爜鑾峰彇锛�
+            if (xj.ItemId == null && !string.IsNullOrEmpty(xj.ItemNo))
+            {
+                // 浠庣墿鏂欑紪鐮佽幏鍙栫墿鏂橧D
+                var itemId = db.Queryable<MesItems>()
+                    .Where(m => m.ItemNo == xj.ItemNo)
+                    .Select(m => m.Id)
+                    .First();
+                
+                if (itemId > 0)
+                {
+                    xj.ItemId = itemId;
+                }
+            }
+            
             // 鏂板锛氫繚瀛橀�佹鎵规
             if (!string.IsNullOrEmpty(rkjDto.RbillNo))
                 xj.RbillNo = rkjDto.RbillNo;
+                
+            // 纭繚Quantity瀛楁琚纭缃�
+            if (xj.Quantity == null && rkjDto.quantity != null)
+            {
+                xj.Quantity = rkjDto.quantity;
+            }
+            
+            // 纭繚鎻愪氦鐘舵�佽姝g‘璁剧疆锛堥粯璁や负鏈彁浜わ級
+            if (xj.Fsubmit == null)
+            {
+                xj.Fsubmit = 0;
+            }
 
             var pid = db.Insertable(xj).ExecuteReturnIdentity();
 
@@ -252,32 +395,32 @@
         //     var transaction = connection.BeginTransaction();
         //
         //     try
-        //     {
-        //         using (var command = new OracleCommand())
         //         {
-        //             command.Connection = connection;
-        //             command.Transaction = transaction;
-        //             command.CommandText = "insert_and_update_picture_RKJ";
-        //             command.CommandType = CommandType.StoredProcedure;
+        //             using (var command = new OracleCommand())
+        //             {
+        //                 command.Connection = connection;
+        //                 command.Transaction = transaction;
+        //                 command.CommandText = "insert_and_update_picture_RKJ";
+        //                 command.CommandType = CommandType.StoredProcedure;
         //
-        //             // Add parameters
-        //             command.Parameters.Add("p_QS_TYPE", OracleDbType.Varchar2)
-        //                 .Value = "3";
-        //             command.Parameters.Add("p_MOID_NUM", OracleDbType.Varchar2)
-        //                 .Value = rkjDto.moidNum;
-        //             command.Parameters.Add("p_pid", OracleDbType.Int32).Value =
-        //                 xj.Id;
+        //                 // Add parameters
+        //                 command.Parameters.Add("p_QS_TYPE", OracleDbType.Varchar2)
+        //                     .Value = "3";
+        //                 command.Parameters.Add("p_MOID_NUM", OracleDbType.Varchar2)
+        //                     .Value = rkjDto.moidNum;
+        //                 command.Parameters.Add("p_pid", OracleDbType.Int32).Value =
+        //                     xj.Id;
         //
-        //             command.ExecuteNonQuery();
+        //                 command.ExecuteNonQuery();
+        //             }
+        //
+        //             transaction.Commit();
         //         }
-        //
-        //         transaction.Commit();
-        //     }
-        //     catch (Exception)
-        //     {
-        //         transaction.Rollback();
-        //         throw;
-        //     }
+        //         catch (Exception)
+        //         {
+        //             transaction.Rollback();
+        //             throw;
+        //         }
         // }
 
         rkjDto.items = GetItems(xj.Id, null);
@@ -457,41 +600,52 @@
     {
         var db = SqlSugarHelper.GetInstance();
 
+        var id = Convert.ToDecimal(queryObj.id);
+
+        string[]? lineNo = null;
+
+        if (StringUtil.IsNotNullOrEmpty(queryObj.createUser))
+            lineNo = _baseService.getUserLineNo(queryObj.createUser);
+
         return db
-            .Queryable<QsItemOqcReq, Womdaa, MesItems, MesInvItemIns, Womdab,
-                MesInvTransaction, RKJDaa001>(
-                (a, da, b, c, d, ca, m) => new JoinQueryInfos(
+            .Queryable<QsItemOqcReq, Womdaa, MesItems>((a, da, b) =>
+                new JoinQueryInfos(
                     JoinType.Left, da.Daa001 == a.BillNo,
-                    JoinType.Left, a.ItemId == b.Id,
-                    JoinType.Left, a.BillNo == c.BillNo,
-                    JoinType.Left, c.CbillNo == d.Dab001,
-                    JoinType.Left,
-                    c.TransctionNo == ca.TransactionNo.ToString() &&
-                    c.Company == ca.Company && c.Factory == ca.Factory,
-                    JoinType.Left, c.Id == m.ItemInId && a.ItemNo == m.ItemNo
+                    JoinType.Left, a.ItemId == b.Id
                 ))
-            .Select((a, da, b, c, d, ca, m) => new QsItemOqcReq
+            .WhereIF(lineNo != null && lineNo.Length > 0,
+                (a, da, b) => lineNo.Contains(da.Daa015))
+            .WhereIF(
+                StringUtil.IsNotNullOrEmpty(queryObj.result) &&
+                "鏈畬鎴�".Equals(queryObj.result),
+                (a, da, b) => a.FcheckResu == null || a.FcheckResu == "")
+            .WhereIF(
+                StringUtil.IsNotNullOrEmpty(queryObj.result) &&
+                !"鏈畬鎴�".Equals(queryObj.result),
+                (a, da, b) => a.FcheckResu != null && a.FcheckResu != "")
+            .WhereIF(id > 0, (a, da, b) => a.Id == id)
+            .Select((a, da, b) => new QsItemOqcReq
             {
-                BillNo = a.BillNo,
-                Remarks = a.Remarks,
                 Id = a.Id,
-                CreateDate = a.CreateDate,
+                ReleaseNo = a.ReleaseNo,
                 CreateBy = a.CreateBy,
-                FcheckResu = a.FcheckResu,
+                CreateDate = a.CreateDate,
+                BillNo = a.BillNo,
+                RbillNo = a.RbillNo,
                 ItemNo = a.ItemNo,
+                ItemId = a.ItemId,
+                LineNo = a.LineNo,
+                FcheckResu = a.FcheckResu,
                 FcheckBy = a.FcheckBy,
                 FcheckDate = a.FcheckDate,
-                ReleaseNo = a.ReleaseNo,
-                RbillNo = a.RbillNo,
-                // 娣诲姞鍏朵粬瀛楁
+                Remarks = a.Remarks,
+                WorkShop = a.WorkShop,
+                DepartmentId = a.DepartmentId,
+                // 浠庡叧鑱旇〃鑾峰彇鐨勫瓧娈�
                 ItemName = b.ItemName,
                 ItemModel = b.ItemModel,
-                TaskNo = c.TaskNo,
-                CbillNo = c.CbillNo,
-                Dab001 = d.Dab001,
                 Daa015 = da.Daa015,
-                LineNo = c.LineNo,
-                Quantity = m.Quantity
+                Quantity = a.Quantity
             }).OrderBy(a => a.CreateDate, OrderByType.Desc)
             .ToPageList(queryObj.PageIndex, queryObj.Limit);
     }
@@ -646,4 +800,55 @@
 
         return Convert.ToInt32(rkjDto.gid);
     }
+
+    /// <summary>
+    /// 鎻愪氦妫�楠屽崟
+    /// </summary>
+    /// <param name="id">妫�楠屽崟ID</param>
+    /// <param name="userNo">鎻愪氦鐢ㄦ埛</param>
+    /// <returns>鏇存柊缁撴灉</returns>
+    public int SubmitInspection(decimal id, string userNo)
+    {
+        return SqlSugarHelper.UseTransactionWithOracle(db =>
+        {
+            return db.Updateable<QsItemOqcReq>()
+                .SetColumns(it => it.Fsubmit == 1) // 璁剧疆鎻愪氦鐘舵�佷负1锛堝凡鎻愪氦锛�
+                .SetColumns(it => it.FcheckBy == userNo) // 璁剧疆妫�楠屼汉
+                .SetColumns(it => it.FcheckDate == DateTime.Now) // 璁剧疆妫�楠屾椂闂�
+                .Where(it => it.Id == id)
+                .ExecuteCommand();
+        });
+    }
+
+    /// <summary>
+    /// 鍒锋柊妫�楠岄」鐩� - 璋冪敤瀛樺偍杩囩▼
+    /// </summary>
+    /// <param name="id">妫�楠屽崟ID</param>
+    /// <param name="no">妫�楠屽崟鍙�</param>
+    /// <param name="user">鐢ㄦ埛</param>
+    /// <returns>鍒锋柊缁撴灉</returns>
+    public (int result, string message) GenUpdate(decimal? id, string? no, string? user)
+    {
+        var outputResult = new SugarParameter("PO_RESULT", null, System.Data.DbType.Int32, ParameterDirection.Output, 4000);
+        var outputMessage = new SugarParameter("PO_TEXT", null, System.Data.DbType.String, ParameterDirection.Output, 4000);
+
+        var parameters = new List<SugarParameter>
+        {
+            new("P_ID", id, System.Data.DbType.Decimal, ParameterDirection.Input),
+            new("P_NO", no, System.Data.DbType.String, ParameterDirection.Input),
+            new("P_USER", user, System.Data.DbType.String, ParameterDirection.Input),
+            outputResult,
+            outputMessage
+        };
+
+        var db = SqlSugarHelper.GetInstance();
+        db.Ado.ExecuteCommand(
+            "BEGIN PRC_GEN_UPDATE3(:P_ID, :P_NO, :P_USER, :PO_RESULT, :PO_TEXT); END;",
+            parameters.ToArray());
+
+        int result = outputResult.Value == null ? -1 : Convert.ToInt32(outputResult.Value);
+        string message = outputMessage.Value?.ToString() ?? "";
+
+        return (result, message);
+    }
 }
\ No newline at end of file
diff --git a/StandardInterface/MESApplication/Controllers/QC/RKJController.cs b/StandardInterface/MESApplication/Controllers/QC/RKJController.cs
index 3aea949..d6e231d 100644
--- a/StandardInterface/MESApplication/Controllers/QC/RKJController.cs
+++ b/StandardInterface/MESApplication/Controllers/QC/RKJController.cs
@@ -87,7 +87,15 @@
     public ResponseResult setJYItem([FromBody] JObject data)
     {
         var itemNo = data["itemNo"].ToString();
-        var quantity = Convert.ToDecimal(data["quantity"].ToString());
+        var quantityStr = data["quantity"]?.ToString();
+        
+        // 澶勭悊quantity涓虹┖鎴栨棤鏁堢殑鎯呭喌
+        decimal quantity = 0;
+        if (!string.IsNullOrEmpty(quantityStr) && decimal.TryParse(quantityStr, out var parsedQuantity))
+        {
+            quantity = parsedQuantity;
+        }
+        
         try
         {
             dynamic resultInfos = new ExpandoObject();
@@ -364,4 +372,146 @@
             return ResponseResult.ResponseError(ex);
         }
     }
+
+    /// <summary>
+    /// 鑾峰彇鏈夌嚎浣撶殑閮ㄩ棬鍒楄〃锛堢敓浜ц溅闂达級
+    /// </summary>
+    /// <returns>閮ㄩ棬鍒楄〃</returns>
+    [HttpPost("GetDepartmentsWithLines")]
+    public ResponseResult GetDepartmentsWithLines()
+    {
+        try
+        {
+            dynamic resultInfos = new ExpandoObject();
+            var tbBillList = new RKJService().GetDepartmentsWithLines();
+            resultInfos.tbBillList = tbBillList;
+            return new ResponseResult
+            {
+                status = 0,
+                message = "OK",
+                data = resultInfos
+            };
+        }
+        catch (Exception ex)
+        {
+            return ResponseResult.ResponseError(ex);
+        }
+    }
+
+    /// <summary>
+    /// 鏍规嵁閮ㄩ棬ID鑾峰彇璇ラ儴闂ㄤ笅鐨勭嚎浣撳垪琛�
+    /// </summary>
+    /// <param name="data">鍖呭惈departmentId鐨凧SON瀵硅薄</param>
+    /// <returns>绾夸綋鍒楄〃</returns>
+    [HttpPost("GetLinesByDepartment")]
+    public ResponseResult GetLinesByDepartment([FromBody] JObject data)
+    {
+        var departmentId = data["departmentId"]?.ToString();
+        try
+        {
+            dynamic resultInfos = new ExpandoObject();
+            var tbBillList = new RKJService().GetLinesByDepartment(departmentId);
+            resultInfos.tbBillList = tbBillList;
+            return new ResponseResult
+            {
+                status = 0,
+                message = "OK",
+                data = resultInfos
+            };
+        }
+        catch (Exception ex)
+        {
+            return ResponseResult.ResponseError(ex);
+        }
+    }
+
+    /// <summary>
+    /// 淇濆瓨閮ㄩ棬閫夋嫨
+    /// </summary>
+    /// <param name="data">鍖呭惈id銆乨epartmentId銆乨epartmentName鐨凧SON瀵硅薄</param>
+    /// <returns>淇濆瓨缁撴灉</returns>
+    [HttpPost("SaveDepartmentSelection")]
+    public ResponseResult SaveDepartmentSelection([FromBody] JObject data)
+    {
+        var id = Convert.ToDecimal(data["id"]?.ToString());
+        var departmentId = data["departmentId"]?.ToString();
+        var departmentName = data["departmentName"]?.ToString();
+        try
+        {
+            dynamic resultInfos = new ExpandoObject();
+            var tbBillList = new RKJService().SaveDepartmentSelection(id, departmentId, departmentName);
+            resultInfos.tbBillList = tbBillList;
+            return new ResponseResult
+            {
+                status = 0,
+                message = "OK",
+                data = resultInfos
+            };
+        }
+        catch (Exception ex)
+        {
+            return ResponseResult.ResponseError(ex);
+        }
+    }
+
+    /// <summary>
+    /// 鎻愪氦妫�楠屽崟
+    /// </summary>
+    /// <param name="data">鍖呭惈id銆乽serNo鐨凧SON瀵硅薄</param>
+    /// <returns>鎻愪氦缁撴灉</returns>
+    [HttpPost("submitInspection")]
+    public ResponseResult SubmitInspection([FromBody] JObject data)
+    {
+        var id = Convert.ToDecimal(data["id"]?.ToString());
+        var userNo = data["userNo"]?.ToString();
+        try
+        {
+            dynamic resultInfos = new ExpandoObject();
+            var tbBillList = new RKJService().SubmitInspection(id, userNo);
+            resultInfos.tbBillList = tbBillList;
+            return new ResponseResult
+            {
+                status = 0,
+                message = "OK",
+                data = resultInfos
+            };
+        }
+        catch (Exception ex)
+        {
+            return ResponseResult.ResponseError(ex);
+        }
+    }
+
+    /// <summary>
+    /// 鍒锋柊妫�楠岄」鐩� - 璋冪敤瀛樺偍杩囩▼
+    /// </summary>
+    /// <param name="data">鍖呭惈id銆乶o銆乽ser鐨凧SON瀵硅薄</param>
+    /// <returns>鍒锋柊缁撴灉</returns>
+    [HttpPost("genUpdate")]
+    public ResponseResult GenUpdate([FromBody] JObject data)
+    {
+        try
+        {
+            decimal? id = data["id"]?.ToObject<decimal>();
+            string? no = data["no"]?.ToString();
+            string? user = data["user"]?.ToString();
+
+            var (result, message) = new RKJService().GenUpdate(id, no, user);
+
+            dynamic resultInfos = new ExpandoObject();
+            resultInfos.result = result;
+            resultInfos.message = message;
+
+            return new ResponseResult
+            {
+                status = 0,
+                message = "OK",
+                data = resultInfos
+            };
+        }
+        catch (Exception ex)
+        {
+            return ResponseResult.ResponseError(ex);
+        }
+    }
 }
\ No newline at end of file
diff --git a/StandardInterface/MESApplication/appsettings.json b/StandardInterface/MESApplication/appsettings.json
index 59a3601..28cfc2a 100644
--- a/StandardInterface/MESApplication/appsettings.json
+++ b/StandardInterface/MESApplication/appsettings.json
@@ -10,6 +10,6 @@
   "AppSettings": {
     "TestErpUrl": "http://192.168.11.120:8098/WebService1.asmx/mesToErpinfo",
     "ProductionErpUrl": "http://192.168.11.120:8098/WebService1.asmx/mesToErpinfoFormal",
-    "DataBaseConn": "Data Source = (DESCRIPTION = (ADDRESS = (PROTOCOL = TCP)(HOST = 192.168.1.22)(PORT = 1521))(CONNECT_DATA = (SERVICE_NAME = ORCL))); Persist Security Info=True;User ID = test_dev; Password=hmprd"
+    "DataBaseConn": "Data Source = (DESCRIPTION = (ADDRESS = (PROTOCOL = TCP)(HOST = 192.168.1.22)(PORT = 1521))(CONNECT_DATA = (SERVICE_NAME = ORCL))); Persist Security Info=True;User ID = hm_prd; Password=hmprd"
   }
 }

--
Gitblit v1.9.3