youruo
2745cf18ff
上一版把同一 SKU 的多个仓位用「、」拼在一格里，库存数量仍是 SKU 总量， 无法直接按仓位盘点。现改为每个仓位独立一行： - bin CTE 改为按 (wms_co_id, sku_id, LTRIM(RTRIM(bin))) 分组， SUM(qty) 得到仓位级库存（各仓位行之和 = SKU 总库存，实测 240=60+69+35+76） - 导出行 = graded（SKU 级「销售=0」判定）LEFT JOIN 仓位级明细： 有仓位数据的 SKU 按仓位展开多行、库存数量取该仓位实际 qty（qty=0 的仓位行剔除）； 仓位表未覆盖的 SKU 保留一行（仓位为空、库存取总库存），不丢数据 - 排序：仓库 → SKU 总库存倒序 → SKU → 仓位名称，同一 SKU 的各行保持相邻 - 前端按钮提示同步更新拆行与兜底规则说明 验证：后端 syntax 通过、单测 9/9（全量 389/390，唯一失败为既有 Windows 环境项）； 前端 eslint/build 通过； 本地实测：单仓（睢宁 196 行，原 128 SKU 行）样例 SKU 正确拆为 4 行且合计 240； 全仓导出 6798 行（原 3650），有仓位行 6529、仓位为空兜底行 269，覆盖 26 仓
249 lines
8.7 KiB
JavaScript
249 lines
8.7 KiB
JavaScript
'use strict';
|
||
|
||
/**
|
||
* 仓库库存动销分析 —— 业务库取数
|
||
*
|
||
* 一次查询覆盖全部仓库 × 全部动销等级：
|
||
* 库存件数：rpt.jst_inventoryInfo 实时库存（按 wms_co_id + sku_id 汇总）
|
||
* 销量： rpt.jst_OrderItem × rpt.jst_Orders，按 send_date，排除 Delete/Cancelled
|
||
* （与「每日进销存」的发货口径一致）
|
||
* 日销： 销量 / 统计窗口天数 → 分档得到动销等级
|
||
*
|
||
* 只统计「有库存或有销量」的 SKU：库存为 0 且窗口内无销量的 SKU 已下架，
|
||
* 计入「销售=0」会虚增分母，故整体剔除。
|
||
*/
|
||
|
||
const { SALES_GRADE_RULES } = require('../config/stockSalesAnalysis');
|
||
|
||
/** mssql 不支持数组参数，按位展开成 @p0,@p1... */
|
||
function buildInClause(values, prefix) {
|
||
const params = {};
|
||
const clause = values
|
||
.map((v, i) => {
|
||
const key = `${prefix}${i}`;
|
||
params[key] = v;
|
||
return `@${key}`;
|
||
})
|
||
.join(',');
|
||
return { clause, params };
|
||
}
|
||
|
||
/**
|
||
* 日销分档表达式：从高档往低档依次命中。
|
||
* 最后一档「销售=0」由 `salesQty <= 0` 兜底（销量为 NULL 视同 0）。
|
||
*/
|
||
function buildGradeCase(salesExpr = 'ISNULL(b.salesQty, 0)', daysParam = '@days') {
|
||
const branches = SALES_GRADE_RULES
|
||
.filter((rule) => rule.lower > 0)
|
||
.map((rule) => {
|
||
const daily = `(${salesExpr} / ${daysParam})`;
|
||
const lower = `${daily} >= ${rule.lower}`;
|
||
const upper = rule.upper == null ? null : `${daily} < ${rule.upper}`;
|
||
const cond = upper ? `${lower} AND ${upper}` : lower;
|
||
return `WHEN ${cond} THEN '${rule.key}'`;
|
||
});
|
||
|
||
return `
|
||
CASE
|
||
${branches.join('\n ')}
|
||
WHEN ${salesExpr} > 0 THEN 'slow2'
|
||
ELSE 'zero'
|
||
END`;
|
||
}
|
||
|
||
/**
|
||
* 每个仓库 × 每个动销等级的 SKU 数、库存件数、销量。
|
||
* @returns {Promise<Array<{wmsCoId:string, gradeKey:string, skuCount:number, stockQty:number, salesQty:number, dailySales:number}>>}
|
||
*/
|
||
async function fetchGradeRows(cloudDb, wmsCoIds, { shipFrom, shipTo, days }) {
|
||
if (!cloudDb || typeof cloudDb.query !== 'function') {
|
||
throw new TypeError('fetchGradeRows 的第一个参数必须是业务库实例');
|
||
}
|
||
if (!Array.isArray(wmsCoIds) || wmsCoIds.length === 0) return [];
|
||
if (!shipFrom || !shipTo || !days) return [];
|
||
|
||
const invIn = buildInClause(wmsCoIds, 'w');
|
||
const shipIn = buildInClause(wmsCoIds, 'v');
|
||
const gradeCase = buildGradeCase();
|
||
|
||
const sqlText = `
|
||
WITH inv AS (
|
||
SELECT i.wms_co_id AS wmsCoId,
|
||
i.sku_id AS skuId,
|
||
SUM(CAST(ISNULL(i.qty, 0) AS DECIMAL(18, 2))) AS stockQty
|
||
FROM rpt.jst_inventoryInfo i
|
||
WHERE i.wms_co_id IN (${invIn.clause})
|
||
GROUP BY i.wms_co_id, i.sku_id
|
||
),
|
||
ship AS (
|
||
SELECT o.wms_co_id AS wmsCoId,
|
||
oi.sku_id AS skuId,
|
||
SUM(CAST(ISNULL(oi.qty, 0) AS DECIMAL(18, 2))) AS salesQty
|
||
FROM rpt.jst_OrderItem oi
|
||
JOIN rpt.jst_Orders o ON o.o_id = oi.o_id
|
||
WHERE o.wms_co_id IN (${shipIn.clause})
|
||
AND o.send_date >= @shipFrom
|
||
AND o.send_date < @shipTo
|
||
AND ISNULL(o.status, '') NOT IN ('Delete', 'Cancelled')
|
||
GROUP BY o.wms_co_id, oi.sku_id
|
||
),
|
||
base AS (
|
||
SELECT u.wmsCoId,
|
||
u.skuId,
|
||
SUM(u.stockQty) AS stockQty,
|
||
SUM(u.salesQty) AS salesQty
|
||
FROM (
|
||
SELECT wmsCoId, skuId, stockQty, CAST(0 AS DECIMAL(18, 2)) AS salesQty FROM inv
|
||
UNION ALL
|
||
SELECT wmsCoId, skuId, CAST(0 AS DECIMAL(18, 2)) AS stockQty, salesQty FROM ship
|
||
) u
|
||
GROUP BY u.wmsCoId, u.skuId
|
||
),
|
||
graded AS (
|
||
SELECT b.wmsCoId,
|
||
b.stockQty,
|
||
b.salesQty,
|
||
${gradeCase} AS gradeKey
|
||
FROM base b
|
||
WHERE ABS(ISNULL(b.stockQty, 0)) > 0.0001
|
||
OR ABS(ISNULL(b.salesQty, 0)) > 0.0001
|
||
)
|
||
SELECT g.wmsCoId,
|
||
g.gradeKey,
|
||
COUNT(*) AS skuCount,
|
||
CAST(SUM(ISNULL(g.stockQty, 0)) AS DECIMAL(18, 2)) AS stockQty,
|
||
CAST(SUM(ISNULL(g.salesQty, 0)) AS DECIMAL(18, 2)) AS salesQty,
|
||
CAST(SUM(ISNULL(g.salesQty, 0) / @days) AS DECIMAL(18, 4)) AS dailySales
|
||
FROM graded g
|
||
GROUP BY g.wmsCoId, g.gradeKey`;
|
||
|
||
const rows = await cloudDb.query(sqlText, {
|
||
...invIn.params,
|
||
...shipIn.params,
|
||
shipFrom,
|
||
shipTo,
|
||
days,
|
||
}, { requestTimeout: 180000 });
|
||
|
||
return rows.map((r) => ({
|
||
wmsCoId: String(r.wmsCoId),
|
||
gradeKey: String(r.gradeKey),
|
||
skuCount: Number(r.skuCount) || 0,
|
||
stockQty: Number(r.stockQty) || 0,
|
||
salesQty: Number(r.salesQty) || 0,
|
||
dailySales: Number(r.dailySales) || 0,
|
||
}));
|
||
}
|
||
|
||
/**
|
||
* 「销售=0」档的 SKU 级明细（导出用）。
|
||
* 口径与 fetchGradeRows 完全一致：同一分档表达式命中 gradeKey='zero'，
|
||
* 即统计窗口内销量 <= 0 且「有库存或有销量」的 SKU。
|
||
*
|
||
* 系统仓位取自 rpt.jst_packInventoryInfo.bin（jst_sku.bin 全为空、库存表无仓位字段）。
|
||
* 每个仓位独立一行，库存数量按该仓位的实际 qty 统计（各仓位行之和 = SKU 总库存）：
|
||
* - 有仓位数据的 SKU：按 (wms_co_id, sku_id, bin) 展开，qty=0 的仓位行剔除；
|
||
* - 无仓位数据的 SKU（仓位表未覆盖的仓库）：保留一行，仓位为空、库存取 SKU 总库存，避免丢数。
|
||
* @returns {Promise<Array<{wmsCoId:string, skuId:string, skuName:string, binName:string, stockQty:number, salesQty:number}>>}
|
||
*/
|
||
async function fetchZeroSaleSkuRows(cloudDb, wmsCoIds, { shipFrom, shipTo, days }) {
|
||
if (!cloudDb || typeof cloudDb.query !== 'function') {
|
||
throw new TypeError('fetchZeroSaleSkuRows 的第一个参数必须是业务库实例');
|
||
}
|
||
if (!Array.isArray(wmsCoIds) || wmsCoIds.length === 0) return [];
|
||
if (!shipFrom || !shipTo || !days) return [];
|
||
|
||
const invIn = buildInClause(wmsCoIds, 'w');
|
||
const shipIn = buildInClause(wmsCoIds, 'v');
|
||
const gradeCase = buildGradeCase();
|
||
|
||
const sqlText = `
|
||
WITH bin AS (
|
||
SELECT p.wms_co_id AS wmsCoId,
|
||
p.sku_id AS skuId,
|
||
LTRIM(RTRIM(p.bin)) AS b,
|
||
SUM(CAST(ISNULL(p.qty, 0) AS DECIMAL(18, 2))) AS binQty
|
||
FROM rpt.jst_packInventoryInfo p
|
||
WHERE ISNULL(p.bin, '') <> ''
|
||
AND ISNULL(p.qty, 0) <> 0
|
||
GROUP BY p.wms_co_id, p.sku_id, LTRIM(RTRIM(p.bin))
|
||
),
|
||
inv AS (
|
||
SELECT i.wms_co_id AS wmsCoId,
|
||
i.sku_id AS skuId,
|
||
SUM(CAST(ISNULL(i.qty, 0) AS DECIMAL(18, 2))) AS stockQty
|
||
FROM rpt.jst_inventoryInfo i
|
||
WHERE i.wms_co_id IN (${invIn.clause})
|
||
GROUP BY i.wms_co_id, i.sku_id
|
||
),
|
||
ship AS (
|
||
SELECT o.wms_co_id AS wmsCoId,
|
||
oi.sku_id AS skuId,
|
||
SUM(CAST(ISNULL(oi.qty, 0) AS DECIMAL(18, 2))) AS salesQty
|
||
FROM rpt.jst_OrderItem oi
|
||
JOIN rpt.jst_Orders o ON o.o_id = oi.o_id
|
||
WHERE o.wms_co_id IN (${shipIn.clause})
|
||
AND o.send_date >= @shipFrom
|
||
AND o.send_date < @shipTo
|
||
AND ISNULL(o.status, '') NOT IN ('Delete', 'Cancelled')
|
||
GROUP BY o.wms_co_id, oi.sku_id
|
||
),
|
||
base AS (
|
||
SELECT u.wmsCoId,
|
||
u.skuId,
|
||
SUM(u.stockQty) AS stockQty,
|
||
SUM(u.salesQty) AS salesQty
|
||
FROM (
|
||
SELECT wmsCoId, skuId, stockQty, CAST(0 AS DECIMAL(18, 2)) AS salesQty FROM inv
|
||
UNION ALL
|
||
SELECT wmsCoId, skuId, CAST(0 AS DECIMAL(18, 2)) AS stockQty, salesQty FROM ship
|
||
) u
|
||
GROUP BY u.wmsCoId, u.skuId
|
||
),
|
||
graded AS (
|
||
SELECT b.wmsCoId,
|
||
b.skuId,
|
||
b.stockQty,
|
||
b.salesQty,
|
||
${gradeCase} AS gradeKey
|
||
FROM base b
|
||
WHERE ABS(ISNULL(b.stockQty, 0)) > 0.0001
|
||
OR ABS(ISNULL(b.salesQty, 0)) > 0.0001
|
||
)
|
||
SELECT g.wmsCoId,
|
||
g.skuId,
|
||
ISNULL(s.name, '') AS skuName,
|
||
ISNULL(bn.b, '') AS binName,
|
||
CAST(COALESCE(bn.binQty, g.stockQty) AS DECIMAL(18, 2)) AS stockQty,
|
||
CAST(g.salesQty AS DECIMAL(18, 2)) AS salesQty
|
||
FROM graded g
|
||
LEFT JOIN rpt.jst_sku s ON s.sku_id = g.skuId
|
||
LEFT JOIN bin bn ON bn.wmsCoId = g.wmsCoId AND bn.skuId = g.skuId
|
||
WHERE g.gradeKey = 'zero'
|
||
ORDER BY g.wmsCoId, g.stockQty DESC, g.skuId, bn.b`;
|
||
|
||
const rows = await cloudDb.query(sqlText, {
|
||
...invIn.params,
|
||
...shipIn.params,
|
||
shipFrom,
|
||
shipTo,
|
||
days,
|
||
}, { requestTimeout: 180000 });
|
||
|
||
return rows.map((r) => ({
|
||
wmsCoId: String(r.wmsCoId),
|
||
skuId: String(r.skuId ?? ''),
|
||
skuName: r.skuName == null ? '' : String(r.skuName),
|
||
binName: r.binName == null ? '' : String(r.binName),
|
||
stockQty: Number(r.stockQty) || 0,
|
||
salesQty: Number(r.salesQty) || 0,
|
||
}));
|
||
}
|
||
|
||
module.exports = {
|
||
buildInClause,
|
||
buildGradeCase,
|
||
fetchGradeRows,
|
||
fetchZeroSaleSkuRows,
|
||
};
|