From 0c7322109660b80e359118de04c0b9cc16a030e3 Mon Sep 17 00:00:00 2001
From: xwt <2740516069@qq.com>
Date: 星期五, 10 十月 2025 15:45:31 +0800
Subject: [PATCH] SJ,XJ,RKJ调用FTP附件

---
 StandardInterface/MES.Service/service/QC/XJService.cs |  105 ++++++++++++++++++++++++++++++++++++++++++++++++----
 1 files changed, 96 insertions(+), 9 deletions(-)

diff --git a/StandardInterface/MES.Service/service/QC/XJService.cs b/StandardInterface/MES.Service/service/QC/XJService.cs
index 0d1564e..de5a9a7 100644
--- a/StandardInterface/MES.Service/service/QC/XJService.cs
+++ b/StandardInterface/MES.Service/service/QC/XJService.cs
@@ -172,6 +172,49 @@
             }
         }
         
+        // 娣诲姞鎼滅储鏉′欢 - 鏍规嵁閫夋嫨鐨勬悳绱㈠瓧娈佃繘琛岀簿纭悳绱�
+        if (!string.IsNullOrEmpty(queryObj.SearchValue) && !string.IsNullOrEmpty(queryObj.searchField))
+        {
+            switch (queryObj.searchField)
+            {
+                case "billNo":  // 宸ュ崟
+                    query = query.Where((s, a, c, b) => s.BillNo.Contains(queryObj.SearchValue));
+                    break;
+                case "releaseNo":  // 妫�楠屽崟鍙�
+                    query = query.Where((s, a, c, b) => s.ReleaseNo.Contains(queryObj.SearchValue));
+                    break;
+                case "daa020":    // 浜х嚎
+                    query = query.Where((s, a, c, b) => c.LineNo.Contains(queryObj.SearchValue));
+                    break;
+                case "itemNo":  // 鐗╂枡缂栫爜
+                    query = query.Where((s, a, c, b) => s.ItemNo.Contains(queryObj.SearchValue));
+                    break;
+                case "itemName":  // 鐗╂枡鍚嶇О
+                    query = query.Where((s, a, c, b) => b.ItemName.Contains(queryObj.SearchValue));
+                    break;
+                default:
+                    // 濡傛灉娌℃湁鎸囧畾瀛楁鎴栧瓧娈典笉鍖归厤锛屼娇鐢ㄥ師鏈夌殑妯$硦鏌ヨ閫昏緫浣滀负鍏滃簳鏂规
+                    query = query.Where((s, a, c, b) => 
+                        s.ItemNo.Contains(queryObj.SearchValue) ||
+                        b.ItemName.Contains(queryObj.SearchValue) ||
+                        s.BillNo.Contains(queryObj.SearchValue) ||
+                        s.ReleaseNo.Contains(queryObj.SearchValue) ||
+                        c.LineNo.Contains(queryObj.SearchValue));
+                    break;
+            }
+        }
+        // 涓轰簡鍏煎鏃х増鏈紝濡傛灉娌℃湁浼犻�� searchField锛屼娇鐢ㄥ師鏉ョ殑鏌ヨ閫昏緫
+        else if (string.IsNullOrEmpty(queryObj.searchField) && !string.IsNullOrEmpty(queryObj.SearchValue))
+        {
+            // 淇濇寔鍘熸湁鐨勫瀛楁妯$硦鏌ヨ閫昏緫
+            query = query.Where((s, a, c, b) => 
+                s.ItemNo.Contains(queryObj.SearchValue) ||
+                b.ItemName.Contains(queryObj.SearchValue) ||
+                s.BillNo.Contains(queryObj.SearchValue) ||
+                s.ReleaseNo.Contains(queryObj.SearchValue) ||
+                c.LineNo.Contains(queryObj.SearchValue));
+        }
+        
         // 娣诲姞ID绛涢�夋潯浠�
         if (id > 0)
         {
@@ -375,8 +418,35 @@
         var xjDto = new XJDto();
 
         var db = SqlSugarHelper.GetInstance();
-        var qsQaItemXj01 =
-            db.Queryable<QsQaItemXj01>().Single(s => s.Id == id);
+        
+        // 浣跨敤JOIN鏌ヨ鑾峰彇瀛愯〃鏁版嵁鍜屼富琛ㄧ殑ItemNo瀛楁
+        var qsQaItemXj01 = db
+            .Queryable<QsQaItemXj01, QsQaItemXj>((a, b) => new JoinQueryInfos(JoinType.Left, a.Pid == b.Id))
+            .Where((a, b) => a.Id == id)
+            .Select((a, b) => new QsQaItemXj01
+            {
+                Id = a.Id,
+                Pid = a.Pid,
+                ProjName = a.ProjName,
+                ItemMod = a.ItemMod,
+                InspectionMethod = a.InspectionMethod,
+                UsingInstruments = a.UsingInstruments,
+                LevelNum = a.LevelNum,
+                MaxValue = a.MaxValue,
+                StandardValue = a.StandardValue,
+                MinValue = a.MinValue,
+                Notes = a.Notes,
+                FcheckLevel = a.FcheckLevel,
+                FacLevel = a.FacLevel,
+                QsCode = a.QsCode,
+                QsName = a.QsName,
+                Picture = a.Picture,
+                Picturename = a.Picturename,
+                IsPass = a.IsPass,
+                Remarks = a.Remarks,
+                // 娣诲姞涓昏〃鐨処temNo瀛楁
+                ItemNo = b.ItemNo
+            }).Single();
 
         if (qsQaItemXj01.IsPass == 0)
             qsQaItemXj01.result = "涓嶅悎鏍�";
@@ -390,7 +460,6 @@
                 Convert.ToBase64String(qsQaItemXj01.Picture);
 
         xjDto.ItemXj01 = qsQaItemXj01;
-
 
         xjDto.ItemXj02s = db.Queryable<QsQaItemXj02>().Where(s => s.Pid == id)
             .ToList();
@@ -708,15 +777,24 @@
     /// 鑾峰彇闄勪欢淇℃伅
     /// </summary>
     /// <param name="itemNo">鐗╂枡缂栫爜</param>
+    /// <param name="projName">椤圭洰鍚嶇О锛堝彲閫夛紝鐢ㄤ簬杩囨护锛�</param>
     /// <returns>闄勪欢鍒楄〃</returns>
-    public List<QamftpDto> GetAttachments(string itemNo)
+    public List<QamftpDto> GetAttachments(string itemNo, string projName = null)
     {
         var db = SqlSugarHelper.GetInstance();
         try
         {
-            return db.Queryable<MesQamftp>()
+            var query = db.Queryable<MesQamftp>()
                 .Where(x => x.ItemNo == itemNo)
-                .OrderBy(x => x.Fdate, OrderByType.Desc)
+                .Where(x => x.Ftype == "宸℃");  // 娣诲姞FTYPE = '宸℃'鐨勯檺鍒�
+            
+            // 濡傛灉浼犲叆浜唒rojName锛屽垯鎸塅version杩囨护
+            if (!string.IsNullOrEmpty(projName))
+            {
+                query = query.Where(x => x.Fversion == projName);
+            }
+            
+            return query.OrderBy(x => x.Fdate, OrderByType.Desc)
                 .Select(x => new QamftpDto
                 {
                     Id = x.Id,
@@ -747,8 +825,9 @@
     /// <param name="itemNo">鐗╂枡缂栫爜</param>
     /// <param name="fileName">鏂囦欢鍚�</param>
     /// <param name="ftpServer">FTP鏈嶅姟鍣ㄥ湴鍧�</param>
+    /// <param name="projName">椤圭洰鍚嶇О锛堝彲閫夛紝鐢ㄤ簬璺緞鏋勫缓锛�</param>
     /// <returns>鏂囦欢瀛楄妭鏁扮粍</returns>
-    public byte[] GetFtpFile(string itemNo, string fileName, string ftpServer)
+    public byte[] GetFtpFile(string itemNo, string fileName, string ftpServer, string projName = null)
     {
         // 鍙傛暟楠岃瘉
         if (string.IsNullOrEmpty(itemNo) || string.IsNullOrEmpty(fileName) || string.IsNullOrEmpty(ftpServer))
@@ -762,8 +841,16 @@
         // 鏍囧噯鍖朏TP鏈嶅姟鍣ㄥ湴鍧�
         string normalizedServer = NormalizeFtpServer(ftpServer);
         
-        // 鏋勫缓FTP鏂囦欢璺緞 - 宸℃浣跨敤OPC鐩綍
-        string ftpPath = $"{normalizedServer}/OPC/{itemNo}/{fileName}";
+        // 鏋勫缓FTP鏂囦欢璺緞 - 宸℃浣跨敤OPC鐩綍锛屽鏋滀紶鍏ヤ簡projName鍒欎娇鐢ㄦ柊鏍煎紡
+        string ftpPath;
+        if (!string.IsNullOrEmpty(projName))
+        {
+            ftpPath = $"{normalizedServer}/OPC/{itemNo}/{projName}/{fileName}";
+        }
+        else
+        {
+            ftpPath = $"{normalizedServer}/OPC/{itemNo}/{fileName}";
+        }
         
         try
         {

--
Gitblit v1.9.3