出库检和退货检验

如洲 陈

5 天以前 fba48d2d676cd9b6d493163aef9d87f6e5090aee

 MES.Service/service/QC/SJService.cs

@@ -4,7 +4,10 @@
using MES.Service.Modes;
using MES.Service.util;
using SqlSugar;
using System.Net;
using System.Xml.Linq;
using System.Data;
using System.Data.Common;

namespace MES.Service.service.QC;

@@ -69,7 +72,7 @@
            .OrderBy(a => a.BillNo, OrderByType.Desc)
            .ToPageList(queryObj.PageIndex, queryObj.Limit);

        if(queryObj.Id != null)
        /*if(queryObj.Id != null)
        {


@@ -88,7 +91,7 @@
                      return commit;
                  });

        }
        }*/

        

@@ -438,7 +441,6 @@
        var count = db.Queryable<QsItemIpiItemDetail>()
            .Where(s => s.Pid == detail.Pid).Count();


        var result = 0;

        if (qsItemIpiItem.LevelNum != count) return 0;
@@ -459,7 +461,6 @@
                return commit;
            });


        //自动判定是否合格
        //获取检验单的检验项目理论个数
        var sum = db.Queryable<QsItemIpiItem>()
@@ -475,28 +476,69 @@
        //实际个数等于理论个数时对检验单进行判定
        if (sum == icount)
        {
            result = 0;

            //获取这个检验单下的所有合格的检验结果
            passCount = db.Queryable<QsItemIpiItemDetail>()
                .Where(s => s.Gid == detail.Gid && s.Fstand == "√").Count();

            //合格的检验结果等于总检验数视为合格
            if (icount == passCount) result = 1;

            useTransactionWithOracle += SqlSugarHelper.UseTransactionWithOracle(
                db =>
                {
                    return db.Updateable<QsItemIpiReq>()
                        .SetColumns(s => s.IsPass == result)
                        .SetColumns(s => s.StatusUser == detail.CreateBy)
                        .SetColumns(s => s.CompleteTime == DateTime.Now)
                        .Where(s => s.Id == detail.Gid)
                        .ExecuteCommand();
                });
            // 调用存储过程进行自动判定和提交
            CallSJAutoResultStoredProcedure(detail.Gid, detail.CreateBy);
        }

        return useTransactionWithOracle;
    }

    /// <summary>
    /// 调用首检自动判定和提交存储过程
    /// </summary>
    /// <param name="gid">首检主表ID</param>
    /// <param name="createBy">操作人</param>
    private void CallSJAutoResultStoredProcedure(decimal? gid, string createBy)
    {
        try
        {
            var db = SqlSugarHelper.GetInstance();
            
            // 获取首检单信息
            var sjInfo = db.Queryable<QsItemIpiReq>()
                .Where(s => s.Id == gid)
                .First();
                
            if (sjInfo == null) return;

            // 定义输出参数
            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_Gid", gid, System.Data.DbType.Decimal, ParameterDirection.Input),
                new("p_Bill_No", sjInfo.BillNo, System.Data.DbType.String, ParameterDirection.Input),
                new("p_User", createBy, System.Data.DbType.String, ParameterDirection.Input),
                outputResult,
                outputMessage
            };

            // 执行存储过程
            db.Ado.ExecuteCommand(
                "BEGIN PRC_MES_SJ_AUTO_RESULT(:p_Gid, :p_Bill_No, :p_User, :o_Result, :o_Msg); END;",
                parameters.ToArray());

            // 获取输出参数的值
            var resultValue = outputResult.Value?.ToString();
            var messageValue = outputMessage.Value?.ToString();

            if ("1".Equals(resultValue)) 
            {
                throw new Exception($"首检自动判定失败: {messageValue}");
            }
        }
        catch (Exception ex)
        {
            // 记录日志但不影响主流程
            Console.WriteLine($"首检自动判定存储过程调用失败: {ex.Message}");
            // 可以根据需要决定是否抛出异常
            // throw new Exception($"首检自动判定失败: {ex.Message}");
        }
    }

    public int UpdateQSItemDetail(QsItemIpiItemDetail detail)
@@ -581,4 +623,80 @@

        return withOracle;
    }



    public List<string> GetFtpFileList(string ftpAddress, string username, string password, string remotePath)
    {
        List<string> fileList = new List<string>();
        try
        {
            // 构造FTP请求的URI
            string requestUri = $"{ftpAddress}/{remotePath}".TrimEnd('/'); // 确保路径格式正确

            // 创建FtpWebRequest对象
            FtpWebRequest ftpRequest = (FtpWebRequest)WebRequest.Create(requestUri);
            ftpRequest.Method = WebRequestMethods.Ftp.ListDirectory;
            ftpRequest.Credentials = new NetworkCredential(username, password);
            ftpRequest.UseBinary = true;

            // 获取响应
            using (FtpWebResponse ftpResponse = (FtpWebResponse)ftpRequest.GetResponse())
            {
                using (StreamReader responseReader = new StreamReader(ftpResponse.GetResponseStream()))
                {
                    string line = responseReader.ReadLine();
                    while (line != null)
                    {
                        fileList.Add(line);
                        line = responseReader.ReadLine();
                    }
                }
            }
        }
        catch (Exception ex)
        {
            Console.WriteLine("获取FTP文件列表时发生错误: " + ex.Message);
            
        }
        return fileList;
    }


    public byte[] DownloadFtpFile(string ftpAddress, string username, string password, string remotePath)
    {
        byte[] fileData = null;
        try
        {
            // 构造FTP请求的URI
            string requestUri = $"{ftpAddress}/{remotePath}".TrimEnd('/'); // 确保路径格式正确

            // 创建FtpWebRequest对象
            FtpWebRequest ftpRequest = (FtpWebRequest)WebRequest.Create(requestUri);
            ftpRequest.Method = WebRequestMethods.Ftp.DownloadFile;
            ftpRequest.Credentials = new NetworkCredential(username, password);
            ftpRequest.UseBinary = true;

            // 获取响应
            using (FtpWebResponse ftpResponse = (FtpWebResponse)ftpRequest.GetResponse())
            {
                using (Stream responseStream = ftpResponse.GetResponseStream())
                using (MemoryStream memoryStream = new MemoryStream())
                {
                    responseStream.CopyTo(memoryStream);
                    fileData = memoryStream.ToArray();
                }
            }
        }
        catch (Exception ex)
        {
            Console.WriteLine("下载FTP文件时发生错误: " + ex.Message);
        }
        return fileData;
    }





}