数据看板更新前后端
This commit is contained in:
@@ -51,4 +51,167 @@ public interface WmsProductMapper extends BaseMapperPlus<WmsProductMapper, WmsPr
|
||||
@Select("SELECT o.customer_name AS region, COUNT(*) AS customerCount " +
|
||||
"FROM wms_order o WHERE o.del_flag=0 GROUP BY o.customer_name")
|
||||
List<CustomerRegionVO> selectCustomerRegion();
|
||||
|
||||
// ========== 新增业务区域查询方法 ==========
|
||||
|
||||
// 业绩区 - 产品销售情况
|
||||
@Select("SELECT p.product_name, p.product_code, " +
|
||||
"SUM(od.quantity) AS salesQuantity, " +
|
||||
"SUM(od.quantity) AS salesAmount, " +
|
||||
"0 AS growthRate, " +
|
||||
"RANK() OVER (ORDER BY SUM(od.quantity) DESC) AS salesRank " +
|
||||
"FROM wms_order_detail od " +
|
||||
"JOIN wms_product p ON od.product_id = p.product_id " +
|
||||
"JOIN wms_order o ON od.order_id = o.order_id " +
|
||||
"WHERE o.order_status = 2 AND o.del_flag = 0 " +
|
||||
"GROUP BY p.product_id, p.product_name, p.product_code " +
|
||||
"ORDER BY salesQuantity DESC LIMIT 10")
|
||||
List<ProductSalesPerformanceVO> selectProductSalesPerformance();
|
||||
|
||||
// 业绩区 - 销售人员业绩
|
||||
@Select("SELECT o.sales_manager AS salesPersonName, " +
|
||||
"COUNT(DISTINCT o.order_id) AS orderCount, " +
|
||||
"SUM(od.quantity) AS salesAmount, " +
|
||||
"ROUND(SUM(CASE WHEN o.order_status = 2 THEN 1 ELSE 0 END) / COUNT(*), 4) AS completionRate, " +
|
||||
"RANK() OVER (ORDER BY SUM(od.quantity) DESC) AS performanceRank " +
|
||||
"FROM wms_order o " +
|
||||
"JOIN wms_order_detail od ON o.order_id = od.order_id " +
|
||||
"WHERE o.del_flag = 0 " +
|
||||
"GROUP BY o.sales_manager " +
|
||||
"ORDER BY salesAmount DESC")
|
||||
List<SalesPersonPerformanceVO> selectSalesPersonPerformance();
|
||||
|
||||
// 业绩区 - 总订单数量统计
|
||||
@Select("SELECT " +
|
||||
"COUNT(*) AS totalOrderCount, " +
|
||||
"SUM(CASE WHEN order_status = 2 THEN 1 ELSE 0 END) AS completedOrderCount, " +
|
||||
"SUM(CASE WHEN order_status = 1 THEN 1 ELSE 0 END) AS inProgressOrderCount, " +
|
||||
"SUM(CASE WHEN order_status = 0 THEN 1 ELSE 0 END) AS pendingOrderCount, " +
|
||||
"SUM(CASE WHEN DATE_FORMAT(create_time, '%Y-%m') = DATE_FORMAT(NOW(), '%Y-%m') THEN 1 ELSE 0 END) AS monthlyNewOrderCount, " +
|
||||
"ROUND(SUM(CASE WHEN order_status = 2 THEN 1 ELSE 0 END) / COUNT(*), 4) AS completionRate " +
|
||||
"FROM wms_order WHERE del_flag = 0")
|
||||
OrderCountStatisticsVO selectOrderCountStatistics();
|
||||
|
||||
// 当前情况区 - 订单所需的产品统计
|
||||
@Select("SELECT p.product_name, p.product_code, " +
|
||||
"SUM(od.quantity) AS orderDemandQuantity, " +
|
||||
"IFNULL(s.stockQuantity, 0) AS currentStockQuantity, " +
|
||||
"SUM(od.quantity) - IFNULL(s.stockQuantity, 0) AS stockGap, " +
|
||||
"COUNT(DISTINCT o.order_id) AS relatedOrderCount " +
|
||||
"FROM wms_order_detail od " +
|
||||
"JOIN wms_product p ON od.product_id = p.product_id " +
|
||||
"JOIN wms_order o ON od.order_id = o.order_id " +
|
||||
"LEFT JOIN (SELECT item_id, SUM(quantity) AS stockQuantity FROM wms_stock WHERE item_type = 'product' AND del_flag = 0 GROUP BY item_id) s ON p.product_id = s.item_id " +
|
||||
"WHERE o.order_status IN (0, 1) AND o.del_flag = 0 " +
|
||||
"GROUP BY p.product_id, p.product_name, p.product_code " +
|
||||
"ORDER BY stockGap DESC")
|
||||
List<OrderProductStatisticsVO> selectOrderProductStatistics();
|
||||
|
||||
// 当前情况区 - 根据BOM计算的原料需求
|
||||
@Select("SELECT p.product_name, p.product_code, " +
|
||||
"rm.raw_material_name AS materialName, " +
|
||||
"rm.raw_material_code AS materialCode, " +
|
||||
"SUM(od.quantity * pb.quantity) AS requiredQuantity, " +
|
||||
"IFNULL(s.stockQuantity, 0) AS currentStockQuantity, " +
|
||||
"IFNULL(it.inTransitQuantity, 0) AS inTransitQuantity, " +
|
||||
"SUM(od.quantity * pb.quantity) - IFNULL(s.stockQuantity, 0) - IFNULL(it.inTransitQuantity, 0) AS stockGap " +
|
||||
"FROM wms_order_detail od " +
|
||||
"JOIN wms_product p ON od.product_id = p.product_id " +
|
||||
"JOIN wms_product_bom pb ON p.product_id = pb.product_id " +
|
||||
"JOIN wms_raw_material rm ON pb.raw_material_id = rm.raw_material_id " +
|
||||
"JOIN wms_order o ON od.order_id = o.order_id " +
|
||||
"LEFT JOIN (SELECT item_id, SUM(quantity) AS stockQuantity FROM wms_stock WHERE item_type = 'raw_material' AND del_flag = 0 GROUP BY item_id) s ON rm.raw_material_id = s.item_id " +
|
||||
"LEFT JOIN (SELECT raw_material_id, SUM(quantity) AS inTransitQuantity FROM wms_purchase_plan_detail WHERE status = 1 GROUP BY raw_material_id) it ON rm.raw_material_id = it.raw_material_id " +
|
||||
"WHERE o.order_status IN (0, 1) AND o.del_flag = 0 " +
|
||||
"GROUP BY p.product_id, p.product_name, p.product_code, rm.raw_material_id, rm.raw_material_name, rm.raw_material_code " +
|
||||
"ORDER BY stockGap DESC")
|
||||
List<ProductMaterialRequirementVO> selectProductMaterialRequirements();
|
||||
|
||||
// 当前情况区 - 原料库存和需求情况
|
||||
@Select("SELECT rm.raw_material_name AS materialName, " +
|
||||
"rm.raw_material_code AS materialCode, " +
|
||||
"IFNULL(s.stockQuantity, 0) AS currentStockQuantity, " +
|
||||
"IFNULL(it.inTransitQuantity, 0) AS inTransitQuantity, " +
|
||||
"IFNULL(req.requiredQuantity, 0) AS totalRequiredQuantity, " +
|
||||
"IFNULL(req.requiredQuantity, 0) - IFNULL(s.stockQuantity, 0) - IFNULL(it.inTransitQuantity, 0) AS stockGap, " +
|
||||
"0 AS safetyStock, " +
|
||||
"CASE " +
|
||||
" WHEN IFNULL(req.requiredQuantity, 0) <= IFNULL(s.stockQuantity, 0) + IFNULL(it.inTransitQuantity, 0) THEN '充足' " +
|
||||
" WHEN IFNULL(req.requiredQuantity, 0) <= IFNULL(s.stockQuantity, 0) + IFNULL(it.inTransitQuantity, 0) + 0 THEN '不足' " +
|
||||
" ELSE '紧急' " +
|
||||
"END AS stockStatus " +
|
||||
"FROM wms_raw_material rm " +
|
||||
"LEFT JOIN (SELECT item_id, SUM(quantity) AS stockQuantity FROM wms_stock WHERE item_type = 'raw_material' AND del_flag = 0 GROUP BY item_id) s ON rm.raw_material_id = s.item_id " +
|
||||
"LEFT JOIN (SELECT raw_material_id, SUM(quantity) AS inTransitQuantity FROM wms_purchase_plan_detail WHERE status = 1 GROUP BY raw_material_id) it ON rm.raw_material_id = it.raw_material_id " +
|
||||
"LEFT JOIN (SELECT pb.raw_material_id, SUM(od.quantity * pb.quantity) AS requiredQuantity " +
|
||||
" FROM wms_order_detail od " +
|
||||
" JOIN wms_order o ON od.order_id = o.order_id " +
|
||||
" JOIN wms_product_bom pb ON od.product_id = pb.product_id " +
|
||||
" WHERE o.order_status IN (0, 1) AND o.del_flag = 0 " +
|
||||
" GROUP BY pb.raw_material_id) req ON rm.raw_material_id = req.raw_material_id " +
|
||||
"ORDER BY stockGap DESC")
|
||||
List<RawMaterialInventoryVO> selectRawMaterialInventory();
|
||||
|
||||
// 推荐区 - 订单维度推荐
|
||||
@Select("SELECT o.order_code, o.customer_name, " +
|
||||
"CASE o.order_status " +
|
||||
" WHEN 0 THEN '新建' " +
|
||||
" WHEN 1 THEN '生产中' " +
|
||||
" WHEN 2 THEN '已完成' " +
|
||||
" WHEN 3 THEN '已取消' " +
|
||||
"END AS orderStatus, " +
|
||||
"CASE " +
|
||||
" WHEN o.order_status = 0 THEN '高' " +
|
||||
" WHEN o.order_status = 1 THEN '中' " +
|
||||
" ELSE '低' " +
|
||||
"END AS priority, " +
|
||||
"CASE " +
|
||||
" WHEN o.order_status = 0 THEN '新订单需要及时处理' " +
|
||||
" WHEN o.order_status = 1 THEN '生产中的订单需要关注进度' " +
|
||||
" ELSE '订单已完成或已取消' " +
|
||||
"END AS recommendationReason, " +
|
||||
"CASE " +
|
||||
" WHEN o.order_status = 0 THEN '开始生产' " +
|
||||
" WHEN o.order_status = 1 THEN '检查生产进度' " +
|
||||
" ELSE '无需操作' " +
|
||||
"END AS suggestedAction, " +
|
||||
"DATE_ADD(o.create_time, INTERVAL 30 DAY) AS estimatedCompletionTime " +
|
||||
"FROM wms_order o " +
|
||||
"WHERE o.order_status IN (0, 1) AND o.del_flag = 0 " +
|
||||
"ORDER BY o.create_time ASC LIMIT 10")
|
||||
List<OrderRecommendationVO> selectOrderRecommendations();
|
||||
|
||||
// 推荐区 - 原料维度推荐
|
||||
@Select("SELECT rm.raw_material_name AS materialName, " +
|
||||
"rm.raw_material_code AS materialCode, " +
|
||||
"GREATEST(0, IFNULL(req.requiredQuantity, 0) - IFNULL(s.stockQuantity, 0) - IFNULL(it.inTransitQuantity, 0)) AS recommendedPurchaseQuantity, " +
|
||||
"'默认供应商' AS recommendedSupplier, " +
|
||||
"CASE " +
|
||||
" WHEN IFNULL(req.requiredQuantity, 0) > IFNULL(s.stockQuantity, 0) + IFNULL(it.inTransitQuantity, 0) + 0 THEN '库存不足，需要紧急采购' " +
|
||||
" WHEN IFNULL(req.requiredQuantity, 0) > IFNULL(s.stockQuantity, 0) + IFNULL(it.inTransitQuantity, 0) THEN '库存不足，建议采购' " +
|
||||
" ELSE '库存充足' " +
|
||||
"END AS recommendationReason, " +
|
||||
"CASE " +
|
||||
" WHEN IFNULL(req.requiredQuantity, 0) > IFNULL(s.stockQuantity, 0) + IFNULL(it.inTransitQuantity, 0) + 0 THEN '紧急' " +
|
||||
" WHEN IFNULL(req.requiredQuantity, 0) > IFNULL(s.stockQuantity, 0) + IFNULL(it.inTransitQuantity, 0) THEN '一般' " +
|
||||
" ELSE '低' " +
|
||||
"END AS urgencyLevel, " +
|
||||
"DATE_ADD(NOW(), INTERVAL 7 DAY) AS estimatedArrivalTime, " +
|
||||
"CASE " +
|
||||
" WHEN IFNULL(req.requiredQuantity, 0) > IFNULL(s.stockQuantity, 0) + IFNULL(it.inTransitQuantity, 0) + 0 THEN '立即采购' " +
|
||||
" WHEN IFNULL(req.requiredQuantity, 0) > IFNULL(s.stockQuantity, 0) + IFNULL(it.inTransitQuantity, 0) THEN '计划采购' " +
|
||||
" ELSE '无需采购' " +
|
||||
"END AS suggestedAction " +
|
||||
"FROM wms_raw_material rm " +
|
||||
"LEFT JOIN (SELECT item_id, SUM(quantity) AS stockQuantity FROM wms_stock WHERE item_type = 'raw_material' AND del_flag = 0 GROUP BY item_id) s ON rm.raw_material_id = s.item_id " +
|
||||
"LEFT JOIN (SELECT raw_material_id, SUM(quantity) AS inTransitQuantity FROM wms_purchase_plan_detail WHERE status = 1 GROUP BY raw_material_id) it ON rm.raw_material_id = it.raw_material_id " +
|
||||
"LEFT JOIN (SELECT pb.raw_material_id, SUM(od.quantity * pb.quantity) AS requiredQuantity " +
|
||||
" FROM wms_order_detail od " +
|
||||
" JOIN wms_order o ON od.order_id = o.order_id " +
|
||||
" JOIN wms_product_bom pb ON od.product_id = pb.product_id " +
|
||||
" WHERE o.order_status IN (0, 1) AND o.del_flag = 0 " +
|
||||
" GROUP BY pb.raw_material_id) req ON rm.raw_material_id = req.raw_material_id " +
|
||||
"WHERE IFNULL(req.requiredQuantity, 0) > IFNULL(s.stockQuantity, 0) + IFNULL(it.inTransitQuantity, 0) " +
|
||||
"ORDER BY (IFNULL(req.requiredQuantity, 0) - IFNULL(s.stockQuantity, 0) - IFNULL(it.inTransitQuantity, 0)) DESC LIMIT 10")
|
||||
List<MaterialRecommendationVO> selectMaterialRecommendations();
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user