namespace NewPdaSqlServer.service.@base
{
    using NewPdaSqlServer.Dto.service;
    using NewPdaSqlServer.entity;
    using SqlSugar;
    using System;
    using static Microsoft.EntityFrameworkCore.DbLoggerCategory;
    using System.Data;
    using NewPdaSqlServer.DB;

    using System.Data.SqlClient;
    using Microsoft.EntityFrameworkCore.Metadata.Internal;


    public class MesPrintMangeer : Repository<dynamic>
    {
        public dynamic getPrintInfo(dynamic query)
        {

            // 使用参数化查询防止SQL注入
            var sqlParams = new List<SugarParameter> { new("@userAccount", query.userName) };

            var sql1 = @"SELECT TOP 1 ip,port fROM print_info A
                           left join SYS_USER_BIND B on A.guid = B.aboutGuid
                           left join SYS_USER C ON C.GUID = B.userGuid
                          WHERE C.ACCOUNT = @userAccount AND B.fType = '打印机'";

            var printInfo = Db.Ado.SqlQuery<dynamic>(sql1, sqlParams);

            if (printInfo.Count < 1 ) throw new Exception("当前用户未绑定打印机，请维护后使用拆分功能！");

            return printInfo;
        }


        public dynamic getCfInfo(dynamic query) // 使用具体类型替代dynamic
        {
            // 参数校验
            if (string.IsNullOrEmpty(query?.cfBarcode))
                throw new ArgumentException("拆分条码不能为空");
            if (string.IsNullOrEmpty(query?.barcode))
                throw new ArgumentException("原始条码不能为空");

            // 使用强类型参数
            var sqlParams = new List<SugarParameter> { 
                new("@cfBar", query.cfBarcode.Trim()),
                new("@oldBar", query.barcode.Trim()) 
            };

            var sql = @"SELECT TOP 1 C.ITEM_NO,C.item_name,C.item_model,B.OLDQTY as QUANTITY,B.CREATE_DATE, '拆分条码' AS BarType,A.ITEM_BARCODE,GETDATE() as print_date
            FROM MES_INV_ITEM_STOCKS A
            LEFT JOIN MES_INV_ITEM_BARCODES B ON A.ITEM_BARCODE = B.ITEM_BARCODE
            LEFT JOIN MES_ITEMS C ON C.item_id = B.ITEM_ID
            WHERE A.ITEM_BARCODE = @cfBar
            
            UNION ALL
            
            SELECT TOP 1 C.ITEM_NO,C.item_name,C.item_model,A.QUANTITY as QUANTITY,B.CREATE_DATE, '原始条码' AS BarType,A.ITEM_BARCODE,GETDATE() as print_date
            FROM MES_INV_ITEM_STOCKS A
            LEFT JOIN MES_INV_ITEM_BARCODES B ON A.ITEM_BARCODE = B.ITEM_BARCODE
            LEFT JOIN MES_ITEMS C ON C.item_id = B.ITEM_ID
            WHERE A.ITEM_BARCODE = @oldBar";

            var mergedData = Db.Ado.SqlQuery<dynamic>(sql, sqlParams);

            if (mergedData.Count < 2) throw new Exception("条码信息存在异常，请联系管理员！");

            return mergedData;
        }

        // // 现场收料展示列表
        // public class PrintBarInfo
        // {
        //     public List<dynamic> cfBarInfo { get; set; }
        //     public List<dynamic> oldBarInfo { get; set; }
        // }

        public dynamic getCfBeforeInfo(dynamic query) // 使用具体类型替代dynamic
        {
            // 参数校验
            if (string.IsNullOrEmpty(query?.cfBarcode))
                throw new ArgumentException("拆分条码不能为空");
            if (string.IsNullOrEmpty(query?.barcode))
                throw new ArgumentException("原始条码不能为空");

            // 使用强类型参数
            var sqlParams = new List<SugarParameter> {
                new("@cfBar", query.cfBarcode.Trim()),
                new("@oldBar", query.barcode.Trim())
            };

            var sql = @"SELECT TOP 1 C.ITEM_NO,C.item_name,C.item_model,B.OLDQTY as QUANTITY,B.CREATE_DATE, '拆分条码' AS BarType,B.ITEM_BARCODE,GETDATE() as print_date
            FROM MES_INV_ITEM_BARCODES B
            LEFT JOIN MES_ITEMS C ON C.item_id = B.ITEM_ID
            WHERE B.ITEM_BARCODE = @cfBar
 
            UNION ALL
 
            SELECT TOP 1 C.ITEM_NO,C.item_name,C.item_model,B.QUANTITY as QUANTITY,B.CREATE_DATE, '原始条码' AS BarType,B.ITEM_BARCODE,GETDATE() as print_date
            FROM  MES_INV_ITEM_BARCODES B
            LEFT JOIN MES_ITEMS C ON C.item_id = B.ITEM_ID
            WHERE B.ITEM_BARCODE = @oldBar";

            var mergedData = Db.Ado.SqlQuery<dynamic>(sql, sqlParams);

            if (mergedData.Count < 2) throw new Exception("条码信息存在异常，请联系管理员！");

            return mergedData;
        }
        /*-------------------------------2025-10-25 重写拆分条码返回信息新增打印人信息返回----------------------------------*/


        public dynamic getCfInfo(dynamic query, dynamic unity) // 使用具体类型替代dynamic
        {
            // 参数校验
            if (string.IsNullOrEmpty(query?.cfBarcode))
                throw new ArgumentException("拆分条码不能为空");
            if (string.IsNullOrEmpty(query?.barcode))
                throw new ArgumentException("原始条码不能为空");

            var printUser = GetPrinterUserNameByAccount(unity.userName.Trim());
      
            // 使用强类型参数
            var sqlParams = new List<SugarParameter> {
                new("@cfBar", query.cfBarcode.Trim()),
                new("@oldBar", query.barcode.Trim()),
                new("@printBy", printUser)
            };

            // 3. 执行SQL查询（通过UNION ALL合并原始条码与拆分后条码的信息）
            var sql = @"SELECT TOP 1 
                    C.ITEM_NO,
                    C.item_name,
                    C.item_model,
                    @printBy AS printBy,
                    B.OLDQTY AS QUANTITY,
                    B.CREATE_DATE,
                    '拆分条码' AS barType,
                    B.ITEM_BARCODE,
                    u.fname AS unit,
                    GETDATE() AS print_date
                FROM MES_INV_ITEM_BARCODES B
                LEFT JOIN MES_ITEMS C ON C.item_id = B.ITEM_ID
                LEFT JOIN MES_UNIT u ON u.id = C.storeunit 
               WHERE B.ITEM_BARCODE = @cfBar

                UNION ALL

                SELECT TOP 1 
                    C.ITEM_NO,
                    C.item_name,
                    C.item_model,
                    @printBy AS printBy,
                    B.QUANTITY AS QUANTITY,
                    B.CREATE_DATE,
                    '原始条码' AS barType,
                    B.ITEM_BARCODE,
                    u.fname AS unit,
                    GETDATE() AS print_date
                FROM MES_INV_ITEM_BARCODES B
                LEFT JOIN MES_ITEMS C ON C.item_id = B.ITEM_ID
                LEFT JOIN MES_UNIT u ON u.id = C.storeunit
                WHERE B.ITEM_BARCODE = @oldBar";

            var mergedData = Db.Ado.SqlQuery<dynamic>(sql, sqlParams);

            if (mergedData.Count < 2) throw new Exception("条码信息存在异常，请联系管理员！");

            return mergedData;
        }





        /// <summary>
        /// 获取入库前拆分的条码信息（含原始条码与拆分后条码的物料、打印相关数据）
        /// </summary>
        /// <param name="query">拆分结果对象（需包含原始条码barcode、拆分后条码cfBarcode）</param>
        /// <param name="unity">查询参数对象（需包含打印人userName）</param>
        /// <returns>合并后的条码信息列表（原始条码+拆分后条码，共2条数据）</returns>
        /// <exception cref="ArgumentException">参数为空时抛出</exception>
        /// <exception cref="Exception">条码信息异常时抛出</exception>
        public dynamic getCfBeforeInfo(dynamic query, dynamic unity) // 注：建议后续替换为具体实体类型（如BarSplitResult、WarehouseQuery）
        {
            // 1. 参数合法性校验（确保核心条码和打印人信息不为空）
            if (string.IsNullOrEmpty(query?.cfBarcode?.Trim()))
                throw new ArgumentException("拆分后条码不能为空");

            if (string.IsNullOrEmpty(query?.barcode?.Trim()))
                throw new ArgumentException("原始条码不能为空");

            if (string.IsNullOrEmpty(unity?.userName?.Trim()))
                throw new ArgumentException("打印人（userName）不能为空");
            
             var printUser = GetPrinterUserNameByAccount(unity.userName.Trim());
            // 2. 构建SQL参数（避免SQL注入，统一处理参数空格）
            var sqlParams = new List<SugarParameter>
            {
            new("@cfBar", query.cfBarcode.Trim()),    // 拆分后的新条码
            new("@oldBar", query.barcode.Trim()),    // 拆分前的原始条码
            new("@printBy", printUser)   // 执行打印操作的用户
           };

            // 3. 执行SQL查询（通过UNION ALL合并原始条码与拆分后条码的信息）
            var sql = @"SELECT TOP 1 
                    C.ITEM_NO,
                    C.item_name,
                    C.item_model,
                    @printBy AS printBy,
                    B.OLDQTY AS QUANTITY,
                    B.CREATE_DATE,
                    '拆分条码' AS barType,
                    B.ITEM_BARCODE,
                    u.fname AS unit,
                    GETDATE() AS print_date
                FROM MES_INV_ITEM_BARCODES B
                LEFT JOIN MES_ITEMS C ON C.item_id = B.ITEM_ID
                LEFT JOIN MES_UNIT u ON u.id = C.storeunit 
               WHERE B.ITEM_BARCODE = @cfBar

                UNION ALL

                SELECT TOP 1 
                    C.ITEM_NO,
                    C.item_name,
                    C.item_model,
                    @printBy AS printBy,
                    B.QUANTITY AS QUANTITY,
                    B.CREATE_DATE,
                    '原始条码' AS barType,
                    B.ITEM_BARCODE,
                    u.fname AS unit,
                    GETDATE() AS print_date
                FROM MES_INV_ITEM_BARCODES B
                LEFT JOIN MES_ITEMS C ON C.item_id = B.ITEM_ID
                LEFT JOIN MES_UNIT u ON u.id = C.storeunit
                WHERE B.ITEM_BARCODE = @oldBar";

            // 4. 执行查询并处理结果
            var mergedData = Db.Ado.SqlQuery<dynamic>(sql, sqlParams);

            // 校验结果：需同时获取到原始条码和拆分后条码的信息（共2条数据）
            if (mergedData?.Count != 2)
                throw new Exception("条码信息存在异常（未查询到完整的原始/拆分条码数据），请联系管理员！");

            return mergedData;
        }



        /// <summary>
        /// 公共方法：根据用户账号查询对应的打印机用户名
        /// </summary>
        /// <param name="userAccount">用户账号（即原unity.userName）</param>
        /// <param name="userPrinterMainTable">用户-打印机关联表名（默认值可根据实际表名配置）</param>
        /// <returns>匹配的打印机用户名</returns>
        /// <exception cref="ArgumentException">入参为空时抛出</exception>
        /// <exception cref="Exception">未查询到数据或结果为空时抛出</exception>
        public string GetPrinterUserNameByAccount(string userAccount)
        {
            // 1. 入参校验
            if (string.IsNullOrEmpty(userAccount?.Trim()))
                throw new ArgumentException("查询打印机用户的入参【userAccount】不能为空");
 

            // 2. 构建参数化查询（防SQL注入）
            var userParams = new List<SugarParameter>
    {
        new("@userAccount", userAccount.Trim())
        
    };

            // 3. 动态表名的SQL（适配不同表名场景）
            var userSql = @"SELECT C.USER_NAME FROM SYS_USER C WHERE C.ACCOUNT = @userAccount ";

            // 4. 执行查询
            var printUsers = Db.Ado.SqlQuery<dynamic>(userSql, userParams);
            if (printUsers == null || printUsers.Count == 0)
                throw new Exception($"未查询到账号【{userAccount}】对应的打印机用户信息");

            // 5. 提取并校验结果（取第一个匹配值，可根据业务调整为多值处理）
            var printUser = printUsers.First()?.USER_NAME?.Trim();
            if (string.IsNullOrEmpty(printUser))
                throw new Exception($"账号【{userAccount}】查询到的打印机用户名为空");

            return printUser;
        }

    }
}