From a619299816f2f632c7c6ba3a1bb869e2c212797d Mon Sep 17 00:00:00 2001
From: fcx <2246384483@qq.com>
Date: 星期五, 19 十二月 2025 14:12:33 +0800
Subject: [PATCH] 对添加巡检单物料编码进行去重

---
 StandardPda/MESApplication/Controllers/QC/SJController.cs |  129 +++++++++++++++++++++++++++++++++++++-----
 1 files changed, 113 insertions(+), 16 deletions(-)

diff --git a/StandardPda/MESApplication/Controllers/QC/SJController.cs b/StandardPda/MESApplication/Controllers/QC/SJController.cs
index 33fa226..aeeb63b 100644
--- a/StandardPda/MESApplication/Controllers/QC/SJController.cs
+++ b/StandardPda/MESApplication/Controllers/QC/SJController.cs
@@ -6,9 +6,12 @@
 using Microsoft.AspNetCore.Mvc;
 using Newtonsoft.Json;
 using Newtonsoft.Json.Linq;
+using SixLabors.ImageSharp.Drawing;
+using SqlSugar;
 using System.Collections.Generic;
 using System.Data;
 using System.Dynamic;
+using DbType = System.Data.DbType;
 
 namespace MESApplication.Controllers.QC;
 
@@ -40,7 +43,7 @@
 
 
     [HttpPost("GetPage")]
-    public ResponseResult GetPage([FromBody] SJPageResult queryObj)
+    public ResponseResult GetPage([FromBody] SJPageResult2 queryObj)
     {
         try
         {
@@ -335,8 +338,8 @@
             //------------------ SN鎵爜鏍¢獙 ------------------
             var sql1 =
                 @"select SCAN_ITEM 
-              from ZMZ_TEST.MES_SJ_SCAN_ITEM_CK 
-              where mid='" + rkjDto.gid + "' and sn_no is null";
+                  from ZMZ_TEST.MES_SJ_SCAN_ITEM_CK 
+                  where mid='" + rkjDto.gid + "' and sn_no is null";
 
             var dataTable1 = SQLHelper.ExecuteQuery(sql1);
             string msg = "";
@@ -370,11 +373,11 @@
             //------------------ 涓嶅悎鏍煎浘鐗囨槸鍚︿笂浼犳牎楠� ------------------
             var sql2 =
                 @"select A.id, A.PROJ_NAME, B.id as id2
-              from QS_ITEM_IPI_ITEM A
-              left join MES_QS_IMAGE B on 777 || A.ID = B.FID
-              where A.PID = '" + rkjDto.gid + @"' 
-                and B.id is null 
-                and IS_PASS = 0";
+                  from QS_ITEM_IPI_ITEM A
+                  left join MES_QS_IMAGE B on 777 || A.ID = B.FID
+                  where A.PID = '" + rkjDto.gid + @"' 
+                    and B.id is null 
+                    and IS_PASS = 0";
 
             var dt2 = SQLHelper.ExecuteQuery(sql2);
             if (dt2.Rows.Count > 0)
@@ -396,11 +399,11 @@
             //------------------ 蹇呭~椤瑰浘鐗囨槸鍚︿笂浼犳牎楠� ------------------
             var sql3 =
                 @"select A.id, A.PROJ_NAME, B.id as id2
-              from QS_ITEM_IPI_ITEM A
-              left join MES_QS_IMAGE B on 777 || A.ID = B.FID
-              where A.PID = '" + rkjDto.gid + @"'
-                and B.id is null
-                and UP_FILE = 1";
+                  from QS_ITEM_IPI_ITEM A
+                  left join MES_QS_IMAGE B on 777 || A.ID = B.FID
+                  where A.PID = '" + rkjDto.gid + @"'
+                    and B.id is null
+                    and UP_FILE = 1";
 
             var dt3 = SQLHelper.ExecuteQuery(sql3);
             if (dt3.Rows.Count > 0)
@@ -422,9 +425,9 @@
             //------------------ 鏂板鏍¢獙锛氭鏌ユ槸鍚﹀瓨鍦ㄦ湭瀹屾垚锛圛S_PASS is null锛� ------------------
             var sqlPass =
                 @"select ID, PROJ_NAME 
-              from QS_ITEM_IPI_ITEM
-              where PID = '" + rkjDto.gid + @"'
-                and IS_PASS is null";
+                  from QS_ITEM_IPI_ITEM
+                  where PID = '" + rkjDto.gid + @"'
+                    and IS_PASS is null";
 
             var dtPass = SQLHelper.ExecuteQuery(sqlPass);
             if (dtPass.Rows.Count > 0)
@@ -447,7 +450,90 @@
             dynamic resultInfos = new ExpandoObject();
             var tbBillList = new SJService().SJQaSubmit(rkjDto);
             resultInfos.tbBillList = tbBillList;
+            //=================  鍒ゆ柇妫�楠屽悎鏍肩敓鎴愬贰妫�鍗� =========
+            var sqlpass6 = $@"update QS_ITEM_IPI_REQ set FSUBMIT = 1 where ID = '{rkjDto.gid}' ";
+            var dtPass7 = SQLHelper.ExecuteQuery(sqlpass6);
 
+            var sqlPass1 = $@"
+        SELECT 
+            IS_PASS
+        FROM QS_ITEM_IPI_REQ
+        WHERE  ID = '{rkjDto.gid}'
+         ";
+
+            var dtPass1 = SQLHelper.ExecuteQuery(sqlPass1);
+
+            var sqlPass3 = $@"select C.ID from QS_ITEM_IPI_REQ A
+    LEFT JOIN  V_MES_SJ B on b.BILL_NO = A.BILL_NO
+    LEFT JOIN WOMDAA C on C.DAA001 = B.DAA001
+    WHERE A.ID = '{rkjDto.gid}'
+    ";
+            var dtPass3 = SQLHelper.ExecuteQuery(sqlPass3);
+
+            var value4 = dtPass3.Rows[0][0];
+            int sqlPass2 = Convert.ToInt32(value4);
+
+            bool isPass = false;
+
+
+            if (dtPass1 != null && dtPass1.Rows.Count > 0)
+            {
+                var value = dtPass1.Rows[0]["IS_PASS"]?.ToString();
+
+                // 鍒ゆ柇涓哄悎鏍硷紙IS_PASS = 1锛�
+                if (value == "1")
+                {
+                    var sqlpass4 = $@"update QS_ITEM_IPI_REQ set FSUBMIT1 = 1 where ID = '{rkjDto.gid}' ";
+
+                    var dtPass5 = SQLHelper.ExecuteQuery(sqlpass4);
+
+                    isPass = true;
+                }
+                else
+                {
+                    var sqlpass4 = $@"update QS_ITEM_IPI_REQ set FSUBMIT1 = 0 where ID = '{rkjDto.gid}' ";
+
+                    var dtPass5 = SQLHelper.ExecuteQuery(sqlpass4);
+                }
+            }
+
+            // 濡傛灉鍚堟牸锛屾墽琛屽瓨鍌ㄨ繃绋�
+            if (isPass)
+            {
+                var db = SqlSugarHelper.GetInstance();
+
+                // ===== 杈撳嚭鍙傛暟 =====
+                var outFlag = new SugarParameter("P_FLAG", null,
+                    DbType.Int32, ParameterDirection.Output, 10);
+
+                var outText = new SugarParameter("P_TEXT", null,
+                    DbType.String, ParameterDirection.Output, 4000);
+
+                // ===== 杈撳叆鍙傛暟 =====
+                var parameters = new List<SugarParameter>
+        {
+            new SugarParameter("P_ID", sqlPass2, DbType.Int64, ParameterDirection.Input),
+            new SugarParameter("P_USER", rkjDto.userNo, DbType.String, ParameterDirection.Input),
+            new SugarParameter("P_ISH", 0, DbType.Int64, ParameterDirection.Input),
+
+            // 杈撳嚭鍙傛暟蹇呴』甯︿笂
+            outFlag,
+            outText
+        };
+                // ===== 鎵ц瀛樺偍杩囩▼ =====
+                db.Ado.ExecuteCommand(
+                    "BEGIN PRC_XJ_GENERATE(:P_ID, :P_USER, :P_ISH, :P_FLAG, :P_TEXT); END;",
+                    parameters);
+
+                // ===== 璇诲彇杈撳嚭鍙傛暟骞惰浆鎹㈡垚 ResponseResult =====
+                var result = new ResponseResult
+                {
+                    status = outFlag.Value?.ToString() == "1" ? 1 : 0, // 0 琛ㄧず鎴愬姛锛�1 琛ㄧず澶辫触
+                    message = outText.Value?.ToString()
+                };
+
+                return result;
+            }
             return new ResponseResult
             {
                 status = 0,
@@ -455,6 +541,7 @@
                 data = resultInfos
             };
         }
+
         catch (Exception ex)
         {
             return ResponseResult.ResponseError(ex);
@@ -462,6 +549,16 @@
     }
 
 
+
+
+
+
+
+
+
+
+
+
     /// <summary>
     ///     鑾峰彇涓�鑷存�ф牳瀵归」鐩�
     /// </summary>

--
Gitblit v1.9.3