逻辑优化

快乐的昕的电脑

2025-10-17 1fe2c573d49a5479fa6da2245d26edd9dd07e122

 Services/WomdaaManager.cs

@@ -25,6 +25,13 @@
            list = list.Where(p => p.Daa018 != null && query.OrderStatus.Contains(p.Daa018)).ToList();
        }

        // 按工单ID分组，只保留每组中最早报工的一条
        list = list
            .GroupBy(p => p.ID)
            .Select(g => g.OrderBy(x => x.BgDate).First())
            .OrderBy(x => x.BgDate)
            .ToList();

        return list;
    }

@@ -91,8 +98,7 @@
    {
        // 查询需要显示的工单ID
        var ids = Db.Queryable<MesOrderSelect>()
            .Where(b => b.MachineNo == query.machineNo
                        && b.IsShow == 0)
            .Where(b => b.MachineNo == query.machineNo && b.IsShow == 0)
            .Select(s => s.OrderId)
            .ToList();

@@ -104,12 +110,87 @@
        if (decimals.Count == 0)
            return new List<VOrderBycl>();

        // 查询工单视图，筛选出需要显示的工单
        return Db.Queryable<VOrderBycl>()
        // 查询齿轮数采表
        var numericalList = Db.Queryable<MesNumericalBycl>()
            .Where(x => ids.Contains(x.OrderId ?? 0))
            .OrderBy(x => x.CjTiem)
            .ToList();

        var vOrderBycl = new VOrderBycl();
        if (numericalList.Count > 0)
        {
            // 开工数采：最早一条
            vOrderBycl.StartCjNum = numericalList.First().CjNum ?? 0;
            // 当前数采：最新一条
            vOrderBycl.CurrentCjNum = numericalList.Last().CjNum ?? 0;
        }
        else
        {
            vOrderBycl.StartCjNum = 0;
            vOrderBycl.CurrentCjNum = 0;
        }

        // 查询报工记录，获取最后一条报工记录
        var lastReport = Db.Queryable<MesReporting>()
            .Where(r => r.BillNo != null && r.BillNo.Contains(query.orderNo))
            .OrderBy(r => r.Id, OrderByType.Desc)
            .First();

        if (lastReport == null || !lastReport.BgDate.HasValue)
        {
            // 没有报工记录或报工时间无效，初始采集数为开工采数
            vOrderBycl.InitCjNum = vOrderBycl.StartCjNum;
        }
        else
        {
            // 有报工记录，初始采集数为上一次报工时间后最近一条齿轮数采表的采集数量
            // 1. 精确匹配报工时间
            var exactMatch = numericalList
                .Select(x => new { Item = x, ParsedTime = DateTime.TryParse(x.CjTiem, out var dt) ? dt : (DateTime?)null })
                .Where(x => x.ParsedTime.HasValue && x.ParsedTime.Value == lastReport.BgDate.Value)
                .OrderBy(x => x.ParsedTime)
                .Select(x => x.Item)
                .FirstOrDefault();

            if (exactMatch != null)
            {
                vOrderBycl.InitCjNum = exactMatch.CjNum ?? vOrderBycl.StartCjNum;
            }
            else
            {
                // 2. 找报工时间之后的第一条
                var afterReportNum = numericalList
                    .Select(x => new { Item = x, ParsedTime = DateTime.TryParse(x.CjTiem, out var dt) ? dt : (DateTime?)null })
                    .Where(x => x.ParsedTime.HasValue && x.ParsedTime.Value > lastReport.BgDate.Value)
                    .OrderBy(x => x.ParsedTime)
                    .Select(x => x.Item)
                    .FirstOrDefault();

                vOrderBycl.InitCjNum = afterReportNum?.CjNum ?? vOrderBycl.StartCjNum;
            }
        }

        var startCjNum = vOrderBycl.StartCjNum;
        var currentCjNum = vOrderBycl.CurrentCjNum;
        var initCjNum = vOrderBycl.InitCjNum;

        // 查询工单视图，筛选出需要显示的工单，只取最新一条
        var orders = Db.Queryable<VOrderBycl>()
            .Where(c =>
                decimals.Contains(c.ID) &&
                (c.EditDate == date || c.EditDate == null))
            .OrderBy(c => c.BgDate, OrderByType.Desc)
            .Take(1)
            .ToList();

        foreach (var order in orders)
        {
            order.StartCjNum = startCjNum;
            order.CurrentCjNum = currentCjNum;
            order.InitCjNum = initCjNum;
        }

        return orders;
    }

    /// <summary>
@@ -171,38 +252,51 @@
        var sqlQuerySingle = Db.Ado.SqlQuerySingle<string>(sql);
        VOrdrerBycl.finalResult = sqlQuerySingle;

        // 修复后（确保类型一致，避免参数绑定错误，并防止ID为null时异常）
        var numericalQuery = Db.Queryable<MesNumericalBycl>()
            .Where(n => n.MachineNo == VOrdrerBycl.MachineNo
                        && n.OrderId == (VOrdrerBycl.ID == null ? 0 : VOrdrerBycl.ID)
                        && n.CjNum != null);
        // 查询MES_NUMERICAL_BYCL表，获取开工数采和当前数采
        var numericalList = Db.Queryable<MesNumericalBycl>()
            .Where(x => x.OrderId == VOrdrerBycl.ID)
            .OrderBy(x => x.CjTiem)
            .ToList();

        // 开工采集值=第一条记录(按ID最小)
        var startCjNum = numericalQuery
            .OrderBy(n => n.Id)
            .Select(n => n.CjNum)
        if (numericalList.Count > 0)
        {
            // 开工数采：最早一条
            VOrdrerBycl.StartCjNum = numericalList.First().CjNum ?? 0;
            // 当前数采：最新一条
            VOrdrerBycl.CurrentCjNum = numericalList.Last().CjNum ?? 0;
        }
        else
        {
            VOrdrerBycl.StartCjNum = 0;
            VOrdrerBycl.CurrentCjNum = 0;
        }

        // 查询最后一条报工记录
        var lastReport = Db.Queryable<MesReporting>()
            .Where(r => r.BillNo != null && r.BillNo.Contains(query.orderNo))
            .OrderBy(r => r.Id, OrderByType.Desc)
            .First();

        // 最大采集数（累计当前值）
        var maxCjNum = numericalQuery.Max(n => n.CjNum);
        if (lastReport == null || !lastReport.BgDate.HasValue)
        {
            // 没有报工记录，初始采集数为开工采数
            VOrdrerBycl.InitCjNum = VOrdrerBycl.StartCjNum;
        }
        else
        {
            // 有报工记录，初始采集数为上一次报工时间后最近一条齿轮数采表的采集数量
            var afterReportNum = numericalList
                .Select(x => new { Item = x, ParsedTime = DateTime.TryParse(x.CjTiem, out var dt) ? dt : (DateTime?)null })
                .Where(x => x.ParsedTime.HasValue && x.ParsedTime.Value > lastReport.BgDate.Value)
                .OrderBy(x => x.ParsedTime)
                .Select(x => x.Item)
                .FirstOrDefault();

        // 达到最大值的第一次时间（如需展示可后续新增字段）
        var firstReachMaxTime = numericalQuery
            .Where(n => n.CjNum == maxCjNum)
            .OrderBy(n => n.Id)
            .Select(n => n.CjTiem)
            .First();
            VOrdrerBycl.InitCjNum = afterReportNum?.CjNum ?? VOrdrerBycl.StartCjNum;
        }

        // 达到最大值的最后一次时间（若需要判断是否仍在增长，可对比 first 与 last）
        var lastReachMaxTime = numericalQuery
            .Where(n => n.CjNum == maxCjNum)
            .OrderBy(n => n.Id, OrderByType.Desc)
            .Select(n => n.CjTiem)
            .First();

        // 赋值（CurrentCjNum 采用累计最大值，避免 plateau 重复记录导致误解）
        VOrdrerBycl.StartCjNum = startCjNum ?? 0;
        VOrdrerBycl.CurrentCjNum = maxCjNum ?? 0;
        // 报工时采集数就是主界面的当前采数
        // VOrdrerBycl.CurrentCjNum 已赋值，无需额外处理

        return VOrdrerBycl;
    }
@@ -240,6 +334,16 @@
        return vPrint;
    }

    /// <summary>
    /// 报工记录表
    /// </summary>
    /// <param name="billNo"></param>
    /// <param name="machineNo"></param>
    /// <param name="from"></param>
    /// <param name="to"></param>
    /// <param name="pageIndex"></param>
    /// <param name="pageSize"></param>
    /// <returns></returns>
    public (List<MesReportingBgDto> tbBillList, int totalCount) GetByBillNoBG(
        string billNo, string machineNo, DateTime? from, DateTime? to, int pageIndex, int pageSize)
    {