diff --git a/webapp/controller/ShopController.class.php b/webapp/controller/ShopController.class.php
index 50136932..f571c694 100644
--- a/webapp/controller/ShopController.class.php
+++ b/webapp/controller/ShopController.class.php
@@ -416,7 +416,7 @@ class ShopController extends BaseAuthedController
                     'name' => LogService::RECHARGE_CEBG_BONUS,
                     'val' => $item_num
                 ];
-                LogService::productDiamond(['account_id' => $account_id], $event);
+                LogService::productDiamondCallback(['account_id' => $account_id], $event);
             }
 
             error_log("buyGoodsDirect---" . $address . "---" . $item_id . "---" . $item_num);
diff --git a/webapp/services/callback/ShopBuyGoodsDirect.php b/webapp/services/callback/ShopBuyGoodsDirect.php
index e4a3ea89..673ded55 100644
--- a/webapp/services/callback/ShopBuyGoodsDirect.php
+++ b/webapp/services/callback/ShopBuyGoodsDirect.php
@@ -101,7 +101,12 @@ class ShopBuyGoodsDirect
                 break;
         }
 
-        SqlHelper::update($conn, 't_shop_buy_order', array('idx' => $order_id), array('status' => $buyStatus));
+        SqlHelper::update($conn, 't_shop_buy_order', array('order_id' => $order_id), array('status' => $buyStatus));
+
+        if ($buyStatus == 2) {
+            $this->_rspErr(2, "buyStatus error, buyStatus: {$buyStatus}");
+            return;
+        }
 
         // 以下是看商品表中是否配置了充值额外奖励
         $goods = ShopGoods::get($id);
@@ -121,7 +126,7 @@ class ShopBuyGoodsDirect
                     'name' => LogService::RECHARGE_CEBG_BONUS,
                     'val' => $item_num
                 ];
-                LogService::productDiamond(['account_id' => $account_id], $event);
+                LogService::productDiamondCallback(['account_id' => $account_id], $event);
             }
 
             error_log("buyGoodsDirect---" . $address . "---" . $item_id . "---" . $item_num);