-1

我有一个采购表，用于存储商店收到的所有订单。在某些情况下，我必须以不同的成本重新订购商品。当我进行销售交易时，我需要能够使用由购买日期确定的 FIFO（先进先出）系统来确定所售商品的总成本。

这是我的桌子的样子

CREATE TABLE `purchases` (
  `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
  `item_id` int(11) unsigned NOT NULL,
  `purchased_on` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP,
  `cost` decimal(10,2) unsigned NOT NULL,
  `availableQty` int(11) unsigned NOT NULL,
  PRIMARY KEY (`id`),
  KEY `item_id` (`item_id`)
) ENGINE=InnoDB  DEFAULT CHARSET=utf8;

INSERT INTO `purchases` (`id`, `item_id`, `purchased_on`, `cost`, `availableQty`) VALUES
(1, 1, '2015-01-13 23:50:09', '1.00', 10),
(2, 1, '2015-01-13 23:50:10', '0.90', 20),
(3, 1, '2015-01-13 23:50:11', '0.80', 50),
(4, 2, '2015-01-13 23:50:11', '10.80', 18),
(5, 2, '2015-01-13 23:50:11', '20.25', 235);

使用上面的数据，如果有人想购买 40 个 item_id = 1 的单位，那么成本计算如下 (10 X 1.00) + (20 X 0.90) + (10 X 0.80) = 36 。item_id = 1 的此交易的总成本为 36 美元。

但现在，我需要 availableQty使用新的可用值更新该列。

根据列中的值availableQty，第 1 行和第 2 行在列中的值应为 0， availableQty对于同一列的第 3 行，应为 40。

为了计算交易成本，我可以编写这个查询来计算成本。

SET @orgMyQty = 40;
SET @myQty = @orgMyQty;
SELECT SUM(cost) AS total_cost, SUM(availableQty) AS totalAvailable, SUM(availableQty) - @orgMyQty AS RemainingUnites
FROM (
    SELECT 
    CASE WHEN availableQty >= @myQty THEN cost * @myQty
         ELSE cost * availableQty END AS cost,
    CASE WHEN @myQty > availableQty THEN @myQty := @myQty - availableQty END AS left_over,
    availableQty
    FROM purchases
    WHERE item_id = 1 AND @myQty > 0
    ORDER BY purchased_on ASC, item_id ASC
) AS t

但是如何使用新的 totalAvailable 值更新每一行？

所以最终的记录需要看起来像这样

(1, 1, '2015-01-13 23:50:09', '1.00', 0),
(2, 1, '2015-01-13 23:50:10', '0.90', 0),
(3, 1, '2015-01-13 23:50:11', '0.80', 40),
(4, 2, '2015-01-13 23:50:11', '10.80', 18),
(5, 2, '2015-01-13 23:50:11', '20.25', 235);

所以我的问题是这样的

  1. 如何正确执行 UPDATE？
  2. 如何使用查询查询锁定行以进行更新，以便在提交此事务之前没有其他事务可以更改该值。请注意，查询 select 和 update 都在同一个事务中。
  3. 有没有更好的方法来计算成本？

我尝试了以下查询来更新值

-- 这给了我这一行的语法错误@myQty := CASE WHEN @myQty > availableQty THEN @myQty - availableQty ELSE @myQty END

SET @myQty = 40;
UPDATE data_import.purchases
SET qty = CASE WHEN @myQty = 0 THEN 0
               WHEN @myQty > 0 AND availableQty >= @myQty THEN cost * @myQty
               ELSE cost * availableQty END,
@myQty := CASE WHEN @myQty > availableQty THEN @myQty - availableQty  ELSE @myQty END
WHERE item_id = 1
ORDER BY purchased_on ASC, item_id ASC;

我也试过这个查询

-- there is not syntax error here but only the last column was updated incorrectly.
    UPDATE data_import.purchases
    SET qty = CASE WHEN @myQty = 0 THEN 0
                   WHEN @myQty > 0 AND availableQty >= @myQty THEN cost * @myQty
                   ELSE cost * availableQty END
    WHERE item_id = 1 AND @myQty := CASE WHEN @myQty > availableQty THEN @myQty - availableQty  ELSE @myQty END
    ORDER BY purchased_on ASC;
4

1 回答 1

1

这是计算成本的一些不同的解决方案：

select sum(cost *
least(
  availableQty,
    greatest(
      0,
      40-ifnull(
        (select sum(availableQty) from purchases as b where b.id<a.id),
        0
      )
    )
  ))
as totalCost
from purchases as a
where item_id = 1

一些说明它是如何工作的：

返回我们还应该为当前行购买多少：

greatest(
    0,
    40 - ifnull((select sum(availableQty) from purchases as b where b.id<a.id),0)
)

对于每一行，我们计算我们从前几行购买的数量，即我们总结所有前几行的可用数量，从 40 中减去这个数字（我们想要购买的数量），然后我们就剩下了。

这基本上与您已经拥有的循环相同，但是您每次迭代都在减少“休息”，我重新计算整个先前的总和并找到它与总需求之间的差异，所以我在没有循环的情况下为每一行休息。

但是我们可以有负数，这就是我们使用greatest. 所以对于正值（即之前的行没有满足需求），我们得到我们仍然需要从其他行中选择多少，对于所有其他行 - 0，即所有需求都得到满足。

我们可以从当前行“购买”多少：

least(
      availableQty,
      demandRest /* construction above */
      )

我们只是选择全部可用数量或未满足的需求，取决于哪个更小

因此，基本上对于每一行，我们要么得到全部可用数量，要么得到剩余数量，如果前几行满足了需求，则为 0

这是更新的解决方案：

update purchases as u
inner join
(
select id,
least(
  availableQty,
    greatest(
      0,
      40-ifnull(
        (select sum(availableQty) from purchases as b where b.id<a.id),
        0
      )
    )
  )
as usedQty
from purchases as a
where item_id = 1) as t
  on u.id = t.id
  set u.availableQty = u.availableQty-t.usedQty;

小提琴：http ://sqlfiddle.com/#!9/0a756/1

于 2015-01-14T01:49:55.413 回答