diff --git a/assets/zongji.sql b/assets/zongji.sql
index b9bc14a..4d7e86b 100644
--- a/assets/zongji.sql
+++ b/assets/zongji.sql
@@ -9,5 +9,3 @@ CREATE TABLE `util`.`binlogQueue`(
 CREATE USER 'mycdc-producer'@'%' IDENTIFIED BY 'P4$$w0rd';
 GRANT REPLICATION SLAVE, REPLICATION CLIENT, SELECT ON *.* TO 'mycdc-producer'@'%';
 GRANT INSERT, DELETE ON `util`.* TO 'mycdc-producer'@'%';
-
-CREATE USER 'mycdc-producer'@'%' IDENTIFIED BY 'P4$$w0rd';
diff --git a/queues/stock.yml b/queues/stock.yml
index 4f42e64..2324eca 100644
--- a/queues/stock.yml
+++ b/queues/stock.yml
@@ -1,11 +1,11 @@
 query:
-  travel: CALL stock.buyAvailable_refresh('travel', :id)
-  entry: CALL stock.buyAvailable_refresh('entry', :id)
-  buy: CALL stock.buyAvailable_refresh('buy', :id)
-  ticket: CALL stock.outbound_refresh('ticket', :id)
-  sale: CALL stock.outbound_refresh('sale', :id)
-  order: CALL stock.outbound_refresh('order', :id)
-  orderRow: CALL stock.outbound_refresh('orderRow', :id)
+  travel: CALL stock.buyOut_refreshBuy('travel', :id)
+  entry: CALL stock.buyOut_refreshBuy('entry', :id)
+  buy: CALL stock.buyOut_refreshBuy('lot', :id)
+  ticket: CALL stock.buyOut_refreshSale('ticket', :id)
+  sale: CALL stock.buyOut_refreshSale('lot', :id)
+  order: CALL stock.buyOut_refreshOrder('order', :id)
+  orderRow: CALL stock.buyOut_refreshOrder('lot', :id)
 includeSchema:
   vn:
     travel:
@@ -18,6 +18,7 @@ includeSchema:
       - warehouseInFk
       - warehouseOutFk
       - isReceived
+      - isRaid
       events:
       - updaterows
     entry:
@@ -25,11 +26,10 @@ includeSchema:
       columns:
       - id
       - travelFk
-      - isRaid
       events:
       - updaterows
     buy:
-      key: id
+      key: lotFk
       columns:
       - id
       - entryFk
@@ -43,10 +43,11 @@ includeSchema:
       - id
       - warehouseFk
       - shipped
+      - landed
       events:
       - updaterows
     sale:
-      key: id
+      key: lotFk
       columns:
       - id
       - ticketFk
@@ -67,10 +68,11 @@ includeSchema:
       events:
       - updaterows
     orderRow:
-      key: id
+      key: lotFk
       columns:
       - orderFk
       - itemFk
       - warehouseFk
       - shipment
       - amount
+      - created