如何在不同日期减少具有相同 ID 的多条记录

Question

我在一张表中有一些记录，它们的 ID 相同，但日期和数量不同。

Id | Date       | Name | Volume
1  | 01/08/2019 | Item | 2
1  | 02/08/2019 | Item | 3
1  | 03/08/2019 | Item | 5

然后我有一个销售表格，每次用户销售物品时都会减少数量。

我希望它是这样的： 当用户一次卖出 7 件时，减量是这样的

Id | Date       | Name | Volume
1  | 01/08/2019 | Item | 0
1  | 02/08/2019 | Item | 0
1  | 03/08/2019 | Item | 3

从最早的日期开始，当日期的音量不够时，它会减少下一个最旧的日期

但我不知道如何循环。

Answer 1

这里是怎么做的

CREATE TABLE T(
  Id INT,
  Date DATE,
  Name VARCHAR(45),
  Volume INT
);

INSERT INTO T VALUES
(1, '2019-08-01', 'Item', 2),
(1, '2019-08-02', 'Item', 3),
(1, '2019-08-03', 'Item', 5);

SELECT *, CASE WHEN SUM(Volume) OVER(PARTITION BY Id ORDER BY Date) < V THEN 0
               ELSE SUM(Volume) OVER(PARTITION BY Id ORDER BY Date) - V
               END Result
FROM T CROSS JOIN (VALUES(7)) TT(V);

如果你要去UPDATE桌子：

WITH CTE AS
(
  SELECT *, CASE WHEN SUM(Volume) OVER(PARTITION BY Id ORDER BY Date) < V THEN 0
                 ELSE SUM(Volume) OVER(PARTITION BY Id ORDER BY Date) - V
                 END Result
  FROM T CROSS JOIN (VALUES(7)) TT(V)
)
UPDATE T
SET Volume = CTE.Result
FROM T JOIN CTE
ON T.Id = CTE.Id
   AND
   T.Date = CTE.Date;

Demo

---

更新：

这是一个使用相关子查询的新查询

WITH A AS
(
  SELECT *,
         (
           SELECT SUM(TT.Volume)
           FROM T TT
           WHERE TT.Id = T.Id
                 AND
                 TT.Date <= T.Date
                 AND
                 T.Volume >= TT.Volume
         ) R
  FROM T
)
SELECT T.*, CASE WHEN R < 7 THEN 0 ELSE R - 7 END Result
FROM T JOIN A 
ON T.Id = A.Id AND T.[Date] = A.[Date];

Demo for the Correlated subquery

Answer 2

试试下面的代码：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data;

namespace ConsoleApplication124
{
    class Program
    {
        static void Main(string[] args)
        {
            DataTable dt = new DataTable();
            dt.Columns.Add("Id", typeof(int));
            dt.Columns.Add("Date", typeof(DateTime));
            dt.Columns.Add("Name", typeof(string));
            dt.Columns.Add("Volume", typeof(int));

            dt.Rows.Add(new object[] {1, DateTime.Parse("08/01/2019"), "Item", 2});
            dt.Rows.Add(new object[] {1, DateTime.Parse("08/02/2019"), "Item", 3 });
            dt.Rows.Add(new object[] {1, DateTime.Parse("08/03/2019"), "Item", 5 });

            dt = dt.AsEnumerable().OrderBy(x => x.Field<DateTime>("Date")).CopyToDataTable();

            int order = 7;

            foreach(DataRow row in dt.AsEnumerable().Where(x => x.Field<int>("Id") == 1))
            {


                int oldVolume = row.Field<int>("Volume");

                if (oldVolume >= order)
                {
                    row["Volume"] =  row.Field<int>("Volume") - order;
                    break;
                }
                else
                {
                    order -= oldVolume;
                    row["Volume"] = 0;
                }
            }

        }
    }
}