104 lines
6.7 KiB
Java
104 lines
6.7 KiB
Java
package com.baiyue.lastleg.mapper;
|
|
|
|
import com.baiyue.lastleg.dto.CustomerOrderProgress;
|
|
import org.apache.ibatis.annotations.*;
|
|
import java.util.List;
|
|
|
|
/** Batch read of every actual source, never the representative MIN(order_id) on a shared pallet. */
|
|
@Mapper
|
|
public interface CustomerOrderProgressMapper {
|
|
/** 本客户明细决定归属，真实主阶段和实际发车时间决定待排及在途数量。 */
|
|
@Select("""
|
|
<script>
|
|
WITH scheduled AS (
|
|
SELECT line.order_id,SUM(a.planned_package_count) AS packages
|
|
FROM ll_dispatch_order d
|
|
JOIN ll_dispatch_item i ON i.dispatch_order_id=d.id
|
|
JOIN ll_inbound_plan_pallet_allocation a ON a.pallet_id=i.plan_pallet_id
|
|
JOIN ll_inbound_plan_line line ON line.id=a.line_id AND line.customer_id=i.customer_id
|
|
<if test="orderIds != null">
|
|
JOIN ll_order planned_source ON planned_source.id=line.order_id AND planned_source.customer_id=#{customerId}
|
|
AND planned_source.source_order_id IN <foreach collection="orderIds" item="id" open="(" separator="," close=")">#{id}</foreach>
|
|
</if>
|
|
WHERE i.customer_id=#{customerId} AND d.status='ACTIVE'
|
|
AND d.stage IN ('BEFORE_LOADING','LOADING','AFTER_LOADING')
|
|
AND i.warehouse_pallet_id IS NULL
|
|
GROUP BY line.order_id
|
|
UNION ALL
|
|
SELECT b.inbound_order_id AS order_id,SUM(p.available_packages+COALESCE(pk.packages,0)) AS packages
|
|
FROM ll_dispatch_order d
|
|
JOIN ll_dispatch_item i ON i.dispatch_order_id=d.id
|
|
JOIN ll_inventory_position p ON p.customer_id=i.customer_id AND p.pallet_id=i.warehouse_pallet_id
|
|
AND p.overseas_warehouse_id=i.overseas_warehouse_id
|
|
JOIN ll_inventory_balance b ON b.id=p.balance_id AND b.customer_id=i.customer_id
|
|
<if test="orderIds != null">
|
|
JOIN ll_order stock_source ON stock_source.id=b.inbound_order_id AND stock_source.customer_id=#{customerId}
|
|
AND stock_source.source_order_id IN <foreach collection="orderIds" item="id" open="(" separator="," close=")">#{id}</foreach>
|
|
</if>
|
|
LEFT JOIN (SELECT pick.dispatch_item_id,pick.inventory_position_id,SUM(pick.packages) AS packages
|
|
FROM ll_dispatch_pda_pick pick
|
|
<if test="orderIds != null">
|
|
JOIN ll_inventory_position scoped_position ON scoped_position.id=pick.inventory_position_id
|
|
AND scoped_position.customer_id=pick.customer_id
|
|
JOIN ll_inventory_balance scoped_balance ON scoped_balance.id=scoped_position.balance_id
|
|
AND scoped_balance.customer_id=pick.customer_id
|
|
JOIN ll_order scoped_order ON scoped_order.id=scoped_balance.inbound_order_id
|
|
AND scoped_order.customer_id=pick.customer_id
|
|
AND scoped_order.source_order_id IN <foreach collection="orderIds" item="id" open="(" separator="," close=")">#{id}</foreach>
|
|
</if>
|
|
WHERE pick.customer_id=#{customerId}
|
|
GROUP BY pick.dispatch_item_id,pick.inventory_position_id) pk
|
|
ON pk.dispatch_item_id=i.id AND pk.inventory_position_id=p.id
|
|
WHERE i.customer_id=#{customerId} AND d.status='ACTIVE'
|
|
AND d.stage IN ('BEFORE_LOADING','LOADING','AFTER_LOADING')
|
|
AND (i.plan_pallet_id IS NULL OR EXISTS (
|
|
SELECT 1 FROM ll_inbound_plan_pallet_allocation a
|
|
JOIN ll_inbound_plan_line line ON line.id=a.line_id AND line.customer_id=i.customer_id
|
|
<if test="orderIds != null">
|
|
JOIN ll_order planned_source ON planned_source.id=line.order_id AND planned_source.customer_id=#{customerId}
|
|
AND planned_source.source_order_id IN <foreach collection="orderIds" item="id" open="(" separator="," close=")">#{id}</foreach>
|
|
</if>
|
|
WHERE a.pallet_id=i.plan_pallet_id AND line.order_id=b.inbound_order_id))
|
|
GROUP BY b.inbound_order_id
|
|
), departed AS (
|
|
SELECT a.order_id,SUM(a.packages) AS packages
|
|
FROM ll_dispatch_pda_pick_order a
|
|
JOIN ll_dispatch_pda_pick p ON p.id=a.pick_id AND p.customer_id=a.customer_id
|
|
JOIN ll_dispatch_pda_task t ON t.id=p.task_id
|
|
JOIN ll_dispatch_order ds ON ds.id=t.dispatch_order_id
|
|
JOIN ll_dispatch_item i ON i.id=p.dispatch_item_id AND i.dispatch_order_id=ds.id AND i.customer_id=a.customer_id
|
|
<if test="orderIds != null">
|
|
JOIN ll_order departed_source ON departed_source.id=a.order_id AND departed_source.customer_id=#{customerId}
|
|
AND departed_source.source_order_id IN <foreach collection="orderIds" item="id" open="(" separator="," close=")">#{id}</foreach>
|
|
</if>
|
|
WHERE a.customer_id=#{customerId} AND ds.status='ACTIVE' AND ds.stage='DELIVERING'
|
|
AND ds.departed_at IS NOT NULL
|
|
AND EXISTS (
|
|
SELECT 1 FROM ll_delivery_order d
|
|
JOIN ll_outbound_order outb ON outb.id=d.outbound_order_id AND outb.customer_id=d.customer_id
|
|
WHERE d.customer_id=a.customer_id AND d.dispatch_order_id=ds.id
|
|
AND outb.status='OUTBOUNDED' AND d.status IN ('WAIT_DELIVERY','DELIVERING')
|
|
AND d.delivery_group_key=CASE
|
|
WHEN i.destination_type='PRIVATE' AND NULLIF(TRIM(i.delivery_address),'') IS NOT NULL
|
|
THEN CONCAT('PRIVATE:',TRIM(i.delivery_address),':',TRIM(COALESCE(i.postal_code,'')))
|
|
WHEN COALESCE(NULLIF(TRIM(i.destination_warehouse_code),''),NULLIF(TRIM(i.fba_warehouse_code),'')) IS NOT NULL
|
|
THEN CONCAT('CODE:',UPPER(COALESCE(NULLIF(TRIM(i.destination_warehouse_code),''),NULLIF(TRIM(i.fba_warehouse_code),''))))
|
|
WHEN NULLIF(TRIM(i.destination_warehouse_id),'') IS NOT NULL THEN CONCAT('ID:',TRIM(i.destination_warehouse_id))
|
|
ELSE NULL END)
|
|
GROUP BY a.order_id
|
|
)
|
|
SELECT o.source_order_id AS order_id,COALESCE(o.package_count,0) AS packages,
|
|
COALESCE((SELECT SUM(s.packages) FROM scheduled s WHERE s.order_id=o.id),0) AS scheduled_packages,
|
|
COALESCE((SELECT SUM(d.packages) FROM departed d WHERE d.order_id=o.id),0) AS delivering_packages
|
|
FROM ll_order o WHERE o.customer_id=#{customerId} AND o.source_region='FIRSTLEG'
|
|
AND o.source_order_id IS NOT NULL AND o.source_inbound_id IS NOT NULL
|
|
AND o.order_type NOT IN ('RELABEL_APPLICATION','WAREHOUSE_TRANSFER')
|
|
<if test="orderIds != null">
|
|
AND o.source_order_id IN <foreach collection="orderIds" item="id" open="(" separator="," close=")">#{id}</foreach>
|
|
</if>
|
|
ORDER BY o.id
|
|
</script>
|
|
""")
|
|
List<CustomerOrderProgress.Source> sources(@Param("customerId") String customerId, @Param("orderIds") List<String> orderIds);
|
|
}
|