XJ,SJ,RKJ检验项目序号，LLJ单个检验项目FTP附件信息

xwt

2025-10-30 dabfdd9dbf0364b1134daaad86af7e13f6437295

 StandardInterface/MES.Service/service/QC/SJService.cs

@@ -44,69 +44,145 @@
        if (StringUtil.IsNotNullOrEmpty(queryObj.StatusUser))
            lineNo = _baseService.getUserLineNo(queryObj.StatusUser);

        var query = db.Queryable<SJPageResult>()
            .WhereIF(lineNo != null && lineNo.Length > 0,
                a => lineNo.Contains(a.line))
            .WhereIF(queryObj.Id != null, a => a.Id == queryObj.Id)
            .WhereIF(StringUtil.IsNotNullOrEmpty(queryObj.BillNo),
                a => a.BillNo == queryObj.BillNo)
            .WhereIF(
                StringUtil.IsNotNullOrEmpty(queryObj.Result) &&
                "未完成".Equals(queryObj.Result),
                a => a.Fsubmit == 0)
            .WhereIF(
                StringUtil.IsNotNullOrEmpty(queryObj.Result) &&
                !"未完成".Equals(queryObj.Result),
                a => a.Fsubmit == 1);

        // 新增的动态搜索逻辑
        if (!string.IsNullOrEmpty(queryObj.SearchValue) && !string.IsNullOrEmpty(queryObj.searchField))
        // 如果有车间或线体筛选，需要联接 MES_LINE 表
        if (!string.IsNullOrEmpty(queryObj.departmentId) || !string.IsNullOrEmpty(queryObj.lineId))
        {
            switch (queryObj.searchField)
            var query = db.Queryable<SJPageResult, MesLine>((a, m) => 
                    new JoinQueryInfos(JoinType.Left, a.line == m.LineNo))
                .WhereIF(lineNo != null && lineNo.Length > 0,
                    (a, m) => lineNo.Contains(a.line))
                .WhereIF(queryObj.Id != null, (a, m) => a.Id == queryObj.Id)
                .WhereIF(StringUtil.IsNotNullOrEmpty(queryObj.BillNo),
                    (a, m) => a.BillNo == queryObj.BillNo)
                .WhereIF(
                    StringUtil.IsNotNullOrEmpty(queryObj.Result) &&
                    "未完成".Equals(queryObj.Result),
                    (a, m) => a.Fsubmit == 0)
                .WhereIF(
                    StringUtil.IsNotNullOrEmpty(queryObj.Result) &&
                    !"未完成".Equals(queryObj.Result),
                    (a, m) => a.Fsubmit == 1)
                // 添加车间筛选
                .WhereIF(!string.IsNullOrEmpty(queryObj.departmentId),
                    (a, m) => m.DepotId.ToString() == queryObj.departmentId)
                // 添加线体筛选
                .WhereIF(!string.IsNullOrEmpty(queryObj.lineId),
                    (a, m) => m.LineNo == queryObj.lineId);

            // 添加搜索条件
            if (!string.IsNullOrEmpty(queryObj.SearchValue) && !string.IsNullOrEmpty(queryObj.searchField))
            {
                case "daa001":  // 工单
                    query = query.Where(x => x.daa001.Contains(queryObj.SearchValue));
                    break;
                case "billNo":  // 检验单号
                    query = query.Where(x => x.BillNo.Contains(queryObj.SearchValue));
                    break;
                case "line":    // 产线
                    query = query.Where(x => x.line.Contains(queryObj.SearchValue));
                    break;
                case "itemNo":  // 物料编码
                    query = query.Where(x => x.ItemNo.Contains(queryObj.SearchValue));
                    break;
                case "daa003":  // 物料名称
                    query = query.Where(x => x.Daa003.Contains(queryObj.SearchValue));
                    break;
                default:
                    // 如果没有指定字段或字段不匹配，使用原有的模糊查询逻辑作为兜底方案
                    query = query.Where(x => 
                        x.ItemNo.Contains(queryObj.SearchValue) ||
                        x.Daa003.Contains(queryObj.SearchValue) ||
                        x.daa001.Contains(queryObj.SearchValue) ||
                        x.BillNo.Contains(queryObj.SearchValue) ||
                        x.line.Contains(queryObj.SearchValue));
                    break;
                switch (queryObj.searchField)
                {
                    case "daa001":  // 工单
                        query = query.Where((a, m) => a.daa001.Contains(queryObj.SearchValue));
                        break;
                    case "billNo":  // 检验单号
                        query = query.Where((a, m) => a.BillNo.Contains(queryObj.SearchValue));
                        break;
                    case "line":    // 产线
                        query = query.Where((a, m) => a.line.Contains(queryObj.SearchValue));
                        break;
                    case "itemNo":  // 物料编码
                        query = query.Where((a, m) => a.ItemNo.Contains(queryObj.SearchValue));
                        break;
                    case "daa003":  // 物料名称
                        query = query.Where((a, m) => a.Daa003.Contains(queryObj.SearchValue));
                        break;
                    default:
                        query = query.Where((a, m) => 
                            a.ItemNo.Contains(queryObj.SearchValue) ||
                            a.Daa003.Contains(queryObj.SearchValue) ||
                            a.daa001.Contains(queryObj.SearchValue) ||
                            a.BillNo.Contains(queryObj.SearchValue) ||
                            a.line.Contains(queryObj.SearchValue));
                        break;
                }
            }
            else if (string.IsNullOrEmpty(queryObj.searchField) && !string.IsNullOrEmpty(queryObj.SearchValue))
            {
                query = query.Where((a, m) => 
                    a.ItemNo.Contains(queryObj.SearchValue) ||
                    a.Daa003.Contains(queryObj.SearchValue) ||
                    a.daa001.Contains(queryObj.SearchValue) ||
                    a.BillNo.Contains(queryObj.SearchValue) ||
                    a.line.Contains(queryObj.SearchValue));
            }

            var totalCount = 0;
            var data = query.OrderBy((a, m) => a.BillNo, OrderByType.Desc)
                .Select((a, m) => a)
                .ToPageList(queryObj.PageIndex, queryObj.Limit, ref totalCount);

            return (data, totalCount);
        }
        // 为了兼容旧版本，如果没有传递 searchField，使用原来的查询逻辑
        else if (string.IsNullOrEmpty(queryObj.searchField) && !string.IsNullOrEmpty(queryObj.SearchValue))
        else
        {
            // 保持原有的多字段模糊查询逻辑
            query = query.Where(x => 
                x.ItemNo.Contains(queryObj.SearchValue) ||
                x.Daa003.Contains(queryObj.SearchValue) ||
                x.daa001.Contains(queryObj.SearchValue) ||
                x.BillNo.Contains(queryObj.SearchValue) ||
                x.line.Contains(queryObj.SearchValue));
            // 没有车间和线体筛选时，使用原来的查询逻辑
            var query = db.Queryable<SJPageResult>()
                .WhereIF(lineNo != null && lineNo.Length > 0,
                    a => lineNo.Contains(a.line))
                .WhereIF(queryObj.Id != null, a => a.Id == queryObj.Id)
                .WhereIF(StringUtil.IsNotNullOrEmpty(queryObj.BillNo),
                    a => a.BillNo == queryObj.BillNo)
                .WhereIF(
                    StringUtil.IsNotNullOrEmpty(queryObj.Result) &&
                    "未完成".Equals(queryObj.Result),
                    a => a.Fsubmit == 0)
                .WhereIF(
                    StringUtil.IsNotNullOrEmpty(queryObj.Result) &&
                    !"未完成".Equals(queryObj.Result),
                    a => a.Fsubmit == 1);

            // 新增的动态搜索逻辑
            if (!string.IsNullOrEmpty(queryObj.SearchValue) && !string.IsNullOrEmpty(queryObj.searchField))
            {
                switch (queryObj.searchField)
                {
                    case "daa001":  // 工单
                        query = query.Where(x => x.daa001.Contains(queryObj.SearchValue));
                        break;
                    case "billNo":  // 检验单号
                        query = query.Where(x => x.BillNo.Contains(queryObj.SearchValue));
                        break;
                    case "line":    // 产线
                        query = query.Where(x => x.line.Contains(queryObj.SearchValue));
                        break;
                    case "itemNo":  // 物料编码
                        query = query.Where(x => x.ItemNo.Contains(queryObj.SearchValue));
                        break;
                    case "daa003":  // 物料名称
                        query = query.Where(x => x.Daa003.Contains(queryObj.SearchValue));
                        break;
                    default:
                        // 如果没有指定字段或字段不匹配，使用原有的模糊查询逻辑作为兜底方案
                        query = query.Where(x => 
                            x.ItemNo.Contains(queryObj.SearchValue) ||
                            x.Daa003.Contains(queryObj.SearchValue) ||
                            x.daa001.Contains(queryObj.SearchValue) ||
                            x.BillNo.Contains(queryObj.SearchValue) ||
                            x.line.Contains(queryObj.SearchValue));
                        break;
                }
            }
            // 为了兼容旧版本，如果没有传递 searchField，使用原来的查询逻辑
            else if (string.IsNullOrEmpty(queryObj.searchField) && !string.IsNullOrEmpty(queryObj.SearchValue))
            {
                // 保持原有的多字段模糊查询逻辑
                query = query.Where(x => 
                    x.ItemNo.Contains(queryObj.SearchValue) ||
                    x.Daa003.Contains(queryObj.SearchValue) ||
                    x.daa001.Contains(queryObj.SearchValue) ||
                    x.BillNo.Contains(queryObj.SearchValue) ||
                    x.line.Contains(queryObj.SearchValue));
            }

            var totalCount = 0;
            var data = query.OrderBy(a => a.BillNo, OrderByType.Desc)
                .ToPageList(queryObj.PageIndex, queryObj.Limit, ref totalCount);

            return (data, totalCount);
        }

        var totalCount = 0;
        var data = query.OrderBy(a => a.BillNo, OrderByType.Desc)
            .ToPageList(queryObj.PageIndex, queryObj.Limit, ref totalCount);

        return (data, totalCount);
    }


@@ -208,7 +284,8 @@
                Mnum = b.Mnum,  // 从主表获取MNUM
                Dnum = b.Dnum,  // 从子表获取DNUM
                Snum = a.Snum,  // 送检批数
                Remarks = a.Remarks
                Remarks = a.Remarks,
                Forder = a.Forder  // 顺序字段
            }).ToList();

        var array = qsItemIpiItems.Select(s => s.Id).ToArray();
@@ -300,8 +377,10 @@
                qsItemIpiItem.imageData = Convert.ToBase64String(s.Picture);
            });

        //排序，未完成的排在前面
        qsItemIpiItems = qsItemIpiItems.OrderBy(s => s.isCheck).ToList();
        //排序：只按FORDER顺序排序
        qsItemIpiItems = qsItemIpiItems
            .OrderBy(s => s.Forder ?? 0)
            .ToList();

        // 为每个检验项目生成穴号信息
        qsItemIpiItems.ForEach(item =>
@@ -676,8 +755,8 @@
        new("P_ID", id, System.Data.DbType.Decimal, ParameterDirection.Input),
        new("P_NO", no, System.Data.DbType.String, ParameterDirection.Input),
        new("P_USER", user, System.Data.DbType.String, ParameterDirection.Input),
        new("P_MNUM", mnum ?? 1, System.Data.DbType.Decimal, ParameterDirection.Input),
        new("P_DNUM", dnum ?? "", System.Data.DbType.String, ParameterDirection.Input),
        new("P_MNUM", mnum, System.Data.DbType.Decimal, ParameterDirection.Input),
        new("P_DNUM", dnum, System.Data.DbType.String, ParameterDirection.Input),
        outputResult,
        outputMessage
    };
@@ -1028,4 +1107,127 @@

        return result;
    }

    /// <summary>
    /// 上传图片到检验项目的PICTURE字段
    /// </summary>
    /// <param name="id">检验项目ID</param>
    /// <param name="imageBytes">图片字节数组</param>
    /// <param name="fileName">原始文件名</param>
    /// <param name="createBy">创建人</param>
    /// <returns>操作结果</returns>
    public (int status, string message) UploadImageToPicture(decimal id, byte[] imageBytes, string fileName, string createBy)
    {
        try
        {
            if (imageBytes == null || imageBytes.Length == 0)
            {
                return (1, "图片数据为空");
            }

            if (string.IsNullOrEmpty(fileName))
            {
                return (1, "文件名为空");
            }

            // 验证图片格式
            var allowedExtensions = new[] { ".jpg", ".jpeg", ".png", ".gif", ".bmp", ".webp" };
            var extension = System.IO.Path.GetExtension(fileName).ToLower();
            if (!allowedExtensions.Contains(extension))
            {
                return (1, "不支持的图片格式，仅支持：jpg, jpeg, png, gif, bmp, webp");
            }

            // 验证图片大小（限制为5MB）
            if (imageBytes.Length > 5 * 1024 * 1024)
            {
                return (1, "图片大小不能超过5MB");
            }

            // 生成时间戳文件名，格式：1746945271304.jpg
            var timestamp = DateTimeOffset.Now.ToUnixTimeMilliseconds();
            var timestampFileName = $"{timestamp}{extension}";

            var result = SqlSugarHelper.UseTransactionWithOracle(db =>
            {
                // 检查检验项目是否存在
                var exists = db.Queryable<QsItemIpiItem>()
                    .Where(s => s.Id == id)
                    .Any();

                if (!exists)
                {
                    throw new Exception("检验项目不存在");
                }

                // 更新PICTURE字段（LONG RAW类型）和PICTURENAME字段（时间戳文件名）
                var updateResult = db.Updateable<QsItemIpiItem>()
                    .SetColumns(s => s.Picture == imageBytes)
                    .SetColumns(s => s.Picturename == timestampFileName)
                    .Where(s => s.Id == id)
                    .ExecuteCommand();

                return updateResult;
            });

            if (result > 0)
            {
                return (0, "图片保存成功");
            }
            else
            {
                return (1, "图片保存失败，未找到对应的检验项目");
            }
        }
        catch (Exception ex)
        {
            return (1, $"图片保存失败：{ex.Message}");
        }
    }

    /// <summary>
    /// 删除检验项目的图片
    /// </summary>
    /// <param name="id">检验项目ID</param>
    /// <returns>操作结果</returns>
    public (int status, string message) DeleteImageFromPicture(decimal id)
    {
        try
        {
            var result = SqlSugarHelper.UseTransactionWithOracle(db =>
            {
                // 检查检验项目是否存在
                var exists = db.Queryable<QsItemIpiItem>()
                    .Where(s => s.Id == id)
                    .Any();

                if (!exists)
                {
                    throw new Exception("检验项目不存在");
                }

                // 清空PICTURE字段和PICTURENAME字段
                var updateResult = db.Updateable<QsItemIpiItem>()
                    .SetColumns(s => s.Picture == null)
                    .SetColumns(s => s.Picturename == null)
                    .Where(s => s.Id == id)
                    .ExecuteCommand();

                return updateResult;
            });

            if (result > 0)
            {
                return (0, "图片删除成功");
            }
            else
            {
                return (1, "图片删除失败，未找到对应的检验项目");
            }
        }
        catch (Exception ex)
        {
            return (1, $"图片删除失败：{ex.Message}");
        }
    }
}