From 5fa361102a4ffb184c311034f08fa2f21ce6e34e Mon Sep 17 00:00:00 2001
From: zjh <2207896513@qq.com>
Date: 星期一, 10 十一月 2025 21:43:48 +0800
Subject: [PATCH] 首检代码提交

---
 StandardPda/MES.Service/service/QC/SJService.cs |  317 ++++++++++++++++++++++++++++++++++++++++++++++++++--
 1 files changed, 304 insertions(+), 13 deletions(-)

diff --git a/StandardPda/MES.Service/service/QC/SJService.cs b/StandardPda/MES.Service/service/QC/SJService.cs
index 639ef64..2e2c364 100644
--- a/StandardPda/MES.Service/service/QC/SJService.cs
+++ b/StandardPda/MES.Service/service/QC/SJService.cs
@@ -3,6 +3,7 @@
 using MES.Service.Modes;
 using MES.Service.util;
 using SqlSugar;
+using System.Data;
 
 namespace MES.Service.service.QC;
 
@@ -241,27 +242,129 @@
     public QsItem SaveItem(QsItem item)
     {
         var qsItemIpiItems = item.Items;
+
         SqlSugarHelper.UseTransactionWithOracle(db =>
         {
-            qsItemIpiItems.ForEach(s => s.Pid = item.gid);
-
-            return db.Insertable(qsItemIpiItems)
+            // 1. 鍒犻櫎鏃х殑瀛愰」
+            db.Deleteable<QsItemIpiItem>()
+                .Where(s => s.Pid == item.gid)
                 .ExecuteCommand();
+
+            qsItemIpiItems.ForEach(s => s.Pid = item.gid);
+            db.Insertable(qsItemIpiItems).ExecuteCommand();
+
+            // 2. 鏌ユ壘 MesQa 瀵瑰簲涓昏〃ID锛堥�氳繃 item.ItemNo锛�
+            var mesQa = db.Queryable<MesQa>()
+                .Where(q => q.ItemNo == item.ItemNo)
+                .Select(q => new { q.Id })
+                .First();
+
+            if (mesQa == null || mesQa.Id == null)
+            {
+                throw new Exception($"鏈壘鍒扮墿鏂欑紪鍙� {item.ItemNo} 瀵瑰簲鐨� MesQa 涓昏〃璁板綍銆�");
+            }
+
+            var mesQaId = mesQa.Id;
+            var mid = item.gid;
+
+            // 3. 鍚屾鎵爜妫�楠岄」鐩〃锛圡ES_SJ_SCAN_ITEM_CK锛�
+            db.Deleteable<MES_SJ_SCAN_ITEM_CK>()
+                .Where(s => s.MID == mid)
+                .ExecuteCommand();
+
+            var scanItems = db.Queryable<MES_SJ_SCAN_ITEM>()
+                .Where(s => s.MID == mesQaId)
+                .Select(s => new MES_SJ_SCAN_ITEM_CK
+                {
+                    SCAN_ITEM = s.SCAN_ITEM,
+                    SN_NO = null,
+                    MID = (long)mid,
+                    CREATE_DATE = DateTime.Now
+                })
+                .ToList();
+
+            foreach (var ck in scanItems)
+            {
+                ck.ID = (long)db.Ado.GetDecimal("SELECT SEQ_MES_SJ_SCAN_ITEM_CK.NEXTVAL FROM DUAL");
+            }
+
+            if (scanItems.Any())
+            {
+                db.Insertable(scanItems).ExecuteCommand();
+            }
+
+            // 4. 涓�鑷存�ч」鐩悓姝ラ�昏緫锛圡ES_IQC_CONSISTENCY_SJ_CK锛�
+            // -------------------------------------------------------------
+            // 鍒犻櫎鏃ф暟鎹�
+            db.Ado.ExecuteCommand(
+                "DELETE FROM MES_IQC_CONSISTENCY_SJ_CK WHERE pid = :IMGID",
+                new { IMGID = item.gid.ToString() });
+
+            // 鏌ヨ涓�鑷存�ч」鐩簮鏁版嵁
+            var consistencyItems = db.SqlQueryable<MES_IQC_CONSISTENCY_SJ_CK>(@"
+            SELECT 
+                a.ID AS PID,
+                b.ItemName,
+                b.ItemMode,
+                b.SuppName,
+                a.Item_No AS ImgID,
+                0 AS IsChack,
+                b.MULTI_SELECT
+            FROM MES_QA a
+            LEFT JOIN MES_IQC_CONSISTENCY_SJ_DT b ON a.ID = b.PID
+            WHERE a.FSUBMIT = 1 
+              AND a.QS_TYPE = 1
+              AND a.ITEM_NO = :ITEM_NO
+              AND b.ItemName IS NOT NULL
+        ").AddParameters(new { ITEM_NO = item.ItemNo }).ToList();
+
+            foreach (var ci in consistencyItems)
+            {
+                db.Ado.ExecuteCommand(@"
+                INSERT INTO MES_IQC_CONSISTENCY_SJ_CK
+                    (ID, PID, ITEMNAME, ITEMMODE, SUPPNAME, IMGID, ISCHACK, MULTI_SELECT)
+                VALUES (
+                    F_GETSEQNEXTVALUE('MES_IQC_CONSISTENCY_SJ_CK'),
+                    :PID,
+                    :ITEMNAME,
+                    :ITEMMODE,
+                    :SUPPNAME,
+                    :IMGID,
+                    :ISCHACK,
+                    :MULTI_SELECT
+                )",
+                    new
+                    {
+                        PID = item.gid,
+                        ITEMNAME = ci.ItemName,
+                        ITEMMODE = ci.ItemMode,
+                        SUPPNAME = ci.SuppName,
+                        IMGID = ci.ImgID,
+                        ISCHACK = ci.ISCHACK,
+                        MULTI_SELECT = ci.MULTI_SELECT
+                    });
+            }
+
+            return 1;
         });
+
+        // 5. 閲嶆柊鍔犺浇妫�楠岄」鐩苟澶勭悊鑷姩鍚堟牸椤�
         item.Items = getQSItems(item.gid, null);
 
-        //娌℃湁涓婁笅闄愮殑妫�楠岄」鐩嚜鍔ㄧ洏鐐逛负鍚堟牸
         item.Items.ForEach(s =>
         {
-            if (s.MaxValue != null || s.StandardValue != null ||
-                s.MinValue != null) return;
-            var detail = new QsItemIpiItemDetail();
-            detail.Pid = s.Id;
-            detail.Gid = item.gid;
-            detail.Fstand = "鈭�";
-            detail.FcheckResu = "1";
-            detail.UpdateBy = item.StatusUser;
-            detail.count = (int?)s.LevelNum;
+            if (s.MaxValue != null || s.StandardValue != null || s.MinValue != null) return;
+
+            var detail = new QsItemIpiItemDetail
+            {
+                Pid = s.Id,
+                Gid = item.gid,
+                Fstand = "鈭�",
+                FcheckResu = "1",
+                UpdateBy = item.StatusUser,
+                count = (int?)s.LevelNum
+            };
+
             SetQSItemDetail(detail);
         });
 
@@ -467,6 +570,8 @@
     
     public bool SJQaSubmit(LLJDto rkjDto)
     {
+        
+
         var useTransactionWithOracle =
             SqlSugarHelper.UseTransactionWithOracle(db =>
             {
@@ -480,4 +585,190 @@
 
         return useTransactionWithOracle > 0;
     }
+
+    public List<Component> getYzxBDlist(string id)
+    {
+        OracleSQLHelper SQLHelper = new();
+        //鏌ュ厓鍣ㄤ欢
+        //var sql1 =
+        //    string.Format(
+        //        @"select ITEMNAME from MES_IQC_CONSISTENCY_ck where PID='" +
+        //        id + "' group by ITEMNAME order by ITEMNAME");
+
+        var sql1 =
+            string.Format(
+                @"select CASE WHEN max(MULTI_SELECT) is null THEN ''ELSE '銆�'||max(MULTI_SELECT)||'銆�' END  as A,ITEMNAME as ITEMNAME   from MES_IQC_CONSISTENCY_SJ_ck where PID='" + id + "' group by ITEMNAME order by ITEMNAME");
+        //鏌ユ槑缁�
+        var sql2 =
+            string.Format(@"select * from MES_IQC_CONSISTENCY_SJ_ck where PID='" +
+                          id + "' order by ITEMNAME,ITEMMODE,SUPPNAME");
+        var dataTable1 = SQLHelper.ExecuteQuery(sql1);
+        var dataTable2 = SQLHelper.ExecuteQuery(sql2);
+        var Components = new List<Component>();
+
+
+        for (var i = 0; i < dataTable1.Rows.Count; i++)
+        {
+            var component = new Component();
+            component.Name = dataTable1.Rows[i]["A"].ToString() + dataTable1.Rows[i]["ITEMNAME"].ToString();
+            component.Specs = new List<string>();
+            component.Manufacturers = new List<string>();
+            component.Id = new List<string>();
+            component.SelectedSpec = -1;
+            component.SelectedMfg = -1;
+            var index = 0;
+            for (var j = 0; j < dataTable2.Rows.Count; j++)
+                if (dataTable2.Rows[j]["ITEMNAME"].ToString() ==
+                    dataTable1.Rows[i]["ITEMNAME"].ToString())
+                {
+                    component.Specs.Add(dataTable2.Rows[j]["ITEMMODE"]
+                        .ToString());
+                    component.Manufacturers.Add(dataTable2.Rows[j]["SUPPNAME"]
+                        .ToString());
+                    component.Id.Add(dataTable2.Rows[j]["ID"].ToString());
+                    if (dataTable2.Rows[j]["ISCHACK"].ToString() == "1")
+                    {
+                        component.SelectedSpec = index;
+                        component.SelectedMfg = index;
+                    }
+
+                    index++;
+                }
+
+            Components.Add(component);
+        }
+
+        return Components;
+    }
+    public DataTable getAllInspectors()
+    {
+        OracleSQLHelper SQLHelper = new();
+        var sql =
+            @"select a.USER_NAME label,U.FCODE value from IQC_BEFORE_FROM_SJ a JOIN SYS_USER U ON U.FID=A.SID";
+        return SQLHelper.ExecuteQuery(sql);
+    }
+
+    /// <summary>
+    ///     涓�鑷存�ч」鐩�
+    /// </summary>
+    public class Component
+    {
+        public string Name { get; set; }
+        public List<string> Specs { get; set; }
+        public List<string> Manufacturers { get; set; }
+        public List<string> Id { get; set; }
+        public int SelectedSpec { get; set; }
+        public int SelectedMfg { get; set; }
+    }
+    public void saveYzxBDlist(string id, DataTable DB)
+    {
+        OracleSQLHelper SQLHelper = new();
+        //鍏堟妸缁撴灉娓呯┖
+        var sql1 =
+            string.Format(
+                @"update MES_IQC_CONSISTENCY_SJ_ck set ISCHACK=0 where PID='" +
+                id + "' ");
+        SQLHelper.ExecuteQuery(sql1);
+        var rowId = "";
+        for (var i = 0; i < DB.Rows.Count; i++)
+            rowId += "'" + DB.Rows[i]["id"] + "',";
+        rowId = rowId.Substring(0, rowId.Length - 1);
+
+
+        //淇敼缁撴灉
+        var sql2 =
+            string.Format(
+                @"update MES_IQC_CONSISTENCY_SJ_ck set ISCHACK=1 where PID='" +
+                id + "'and id in(" + rowId + ") ");
+        SQLHelper.ExecuteQuery(sql2);
+    }
+    public string[] YzxImgVerify(string id)
+    {
+        var msgStr = new string[2];
+
+        OracleSQLHelper SQLHelper = new();
+        //淇敼缁撴灉
+        //var sql2 = string.Format(
+        //    @"select A.ITEMNAME from ( select 888||min(id) id,ITEMNAME from MES_IQC_CONSISTENCY_CK where pid='" +
+        //    id + "' group by  ITEMNAME) A " +
+        //    "left join MES_QS_IMAGE b on a.id=b.fid where B.id is null order by ITEMNAME");
+
+
+        var sql2 = string.Format(
+         @"select A.ITEMNAME from ( select 999||min(id) id,ITEMNAME from MES_IQC_CONSISTENCY_SJ_CK where pid='" + id.ToString() + "' and ITEMNAME not in(select ITEMNAME from MES_IQC_CONSISTENCY_SJ_CK where PID='" + id.ToString() + "'  and MULTI_SELECT is not null)" +
+         "group by  ITEMNAME) A" +
+         " left join MES_QS_IMAGE b on a.id=b.fid where B.id is null" +
+         " union" +
+         " select  '鍒嗙粍锛�' || MULTI_SELECT as ITEMNAME      from MES_IQC_CONSISTENCY_SJ_CK      where pid = '" + id.ToString() + "'        and MULTI_SELECT is not null and MULTI_SELECT not in(select  A.MULTI_SELECT as ITEMNAME from (select 999 || min(id) id, MULTI_SELECT      from MES_IQC_CONSISTENCY_SJ_CK      where pid = '" + id.ToString() + "'       and MULTI_SELECT is not null      group by MULTI_SELECT,ITEMNAME) A        left join MES_QS_IMAGE b on a.id = b.fid where B.id is not null)     group by MULTI_SELECT");
+
+        var db = SQLHelper.ExecuteQuery(sql2);
+        if (db.Rows.Count > 0)
+        {
+            msgStr[1] = "鍏冨櫒浠讹細";
+            for (var i = 0; i < db.Rows.Count; i++)
+                msgStr[1] += db.Rows[i]["ITEMNAME"] + ",";
+            msgStr[1] += "鏈畬鎴愬浘鐗囦笂浼狅紝璇蜂笂浼狅紒";
+            msgStr[0] = "1";
+        }
+        else
+        {
+            msgStr[0] = "0";
+            msgStr[1] = "ok";
+        }
+
+        return msgStr;
+    }
+
+
+    /// <summary>
+    ///     淇濆瓨鏂版楠屽憳
+    /// </summary>
+    /// <param name="NewStaffUserID">鏂版楠屽憳ID</param>
+    /// <param name="userID">淇敼浜�</param>
+    /// <param name="releaseNo">妫�楠屽崟鍙�</param>
+    /// <returns></returns>
+    public string[] SaveCheckBy(string NewStaffUserID, string userID,
+        string releaseNo)
+    {
+        // 瀹氫箟杈撳嚭鍙傛暟
+        var outputResult = new SugarParameter("o_Result", null,
+            System.Data.DbType.Int32, ParameterDirection.Output,
+            4000);
+
+        var outputMessage = new SugarParameter("o_Msg", null,
+            System.Data.DbType.String,
+            ParameterDirection.Output, 4000);
+
+        // 瀹氫箟杈撳叆鍙傛暟
+        var parameters = new List<SugarParameter>
+        {
+            new("P_FCHECK_BY", NewStaffUserID,
+                System.Data.DbType.String, ParameterDirection.Input),
+            new("p_Release_No", releaseNo,
+                System.Data.DbType.String, ParameterDirection.Input),
+            new("p_User", userID,
+                System.Data.DbType.String, ParameterDirection.Input),
+
+            outputResult,
+            outputMessage
+        };
+
+        var db = SqlSugarHelper.GetInstance();
+
+        // 浣跨敤 SqlSugar 鎵ц瀛樺偍杩囩▼
+        db.Ado.ExecuteCommand(
+            "BEGIN Prc_Mes_Pqc_SJ_Update_CheckBy(:P_FCHECK_BY,:p_Release_No,:p_User, :o_Result, :o_Msg); END;",
+            parameters.ToArray());
+
+        // 鑾峰彇杈撳嚭鍙傛暟鐨勫��
+        var resultValue = outputResult.Value?.ToString();
+        var messageValue = outputMessage.Value?.ToString();
+        var msg = new string[2];
+        msg[0] = resultValue;
+        msg[1] = messageValue;
+        return msg;
+    }
+
+
+
 }
\ No newline at end of file

--
Gitblit v1.9.3