diff --git a/webapp/controller/ShopController.class.php b/webapp/controller/ShopController.class.php
index c71e4458..c9f52dc0 100644
--- a/webapp/controller/ShopController.class.php
+++ b/webapp/controller/ShopController.class.php
@@ -204,13 +204,15 @@ class ShopController extends BaseAuthedController
             $this->_rspErr(1, 'goods_num is invalid');
         }
 
-        $conn = myself()->_getMysql('');
+        $conn = myself()->_getSelfMysql();
 
         $address = myself()->_getAddress();
         if (!$address) {
             $this->_rspErr(1, 'address is empty');
         }
 
+        error_log("address: {$address}, id: {$id}, token_type: {$token_type}, goods_num: {$goods_num} " .  $goods['goods_id'], json_encode($goods));
+
         $chk = SqlHelper::insert(
             $conn,
             't_shop_buy_order',
diff --git a/webapp/services/callback/MarketBuyOrderOk.php b/webapp/services/callback/MarketBuyOrderOk.php
index ae4cc87d..c43f71e3 100644
--- a/webapp/services/callback/MarketBuyOrderOk.php
+++ b/webapp/services/callback/MarketBuyOrderOk.php
@@ -1,8 +1,14 @@
 <?php
 
 namespace services;
+require_once('MarketCallbackBase.php');
 
-class MarketBuyOrderOk
+use services\MarketCallbackBase;
+use phpcommon\SqlHelper;
+
+
+
+class MarketBuyOrderOk extends MarketCallbackBase
 {
   public function process()
   {
@@ -33,7 +39,7 @@ class MarketBuyOrderOk
         )
     );
 
-    $conn = myself()->_getSelfMysql();
+    $conn = myself()->_getMysql('');
 
     // 1. check order status
     $chk = SqlHelper::selectOne($conn, 't_market_store', array('status', 'idx', 'c_name', 'token_type'), array('o_link' => $orderId));
diff --git a/webapp/services/callback/MarketCallbackBase.php b/webapp/services/callback/MarketCallbackBase.php
new file mode 100644
index 00000000..0bcc6d37
--- /dev/null
+++ b/webapp/services/callback/MarketCallbackBase.php
@@ -0,0 +1,44 @@
+<?php
+
+namespace services;
+
+use phpcommon\SqlHelper;
+
+class MarketCallbackBase
+{
+  public function _rspOk()
+  {
+    echo json_encode(array(
+      'errcode' => 0,
+      'errmsg' => "callback success",
+    ));
+  }
+
+  public function _rspErr($errcode, $errmsg)
+  {
+    if (SERVER_ENV != _ONLINE) {
+      error_log(json_encode(array(
+        'errcode' => $errcode,
+        'errmsg' => $errmsg,
+      )));
+    }
+    echo json_encode(array(
+      'errcode' => $errcode,
+      'errmsg' => $errmsg,
+    ));
+  }
+
+  protected function addTransactionRecord($record)
+  {
+    $conn = myself()->_getMysql('');
+
+    $r = SqlHelper::insert(
+      $conn,
+      't_market_transaction_record',
+      $record
+    );
+    if (!$r) {
+      $this->_rspErr(2, 'unknown error, orderId=' . $record['orderid']);
+    }
+  }
+}
diff --git a/webapp/services/callback/MarketCancelOrderOk.php b/webapp/services/callback/MarketCancelOrderOk.php
index 8bc36dc2..2681f6f5 100644
--- a/webapp/services/callback/MarketCancelOrderOk.php
+++ b/webapp/services/callback/MarketCancelOrderOk.php
@@ -1,8 +1,12 @@
 <?php
 
 namespace services;
+require_once('MarketCallbackBase.php');
 
-class MarketCancelOrderOk
+use services\MarketCallbackBase;
+use phpcommon\SqlHelper;
+
+class MarketCancelOrderOk extends MarketCallbackBase
 {
   public function process()
   {
@@ -22,7 +26,7 @@ class MarketCancelOrderOk
         )
     );
 
-    $conn = myself()->_getSelfMysql();
+    $conn = myself()->_getMysql('');
 
     // 1. check order status
     $chk = SqlHelper::selectOne($conn, 't_market_store', array('status'), array('o_link' => $orderId));
diff --git a/webapp/services/callback/MarketPriceUpdateOrderOk.php b/webapp/services/callback/MarketPriceUpdateOrderOk.php
index 5ca9a52d..e916c5e1 100644
--- a/webapp/services/callback/MarketPriceUpdateOrderOk.php
+++ b/webapp/services/callback/MarketPriceUpdateOrderOk.php
@@ -1,8 +1,12 @@
 <?php
 
 namespace services;
+require_once('MarketCallbackBase.php');
 
-class MarketPriceUpdateOrderOk
+use services\MarketCallbackBase;
+use phpcommon\SqlHelper;
+
+class MarketPriceUpdateOrderOk extends MarketCallbackBase
 {
   public function process()
   {
@@ -26,7 +30,7 @@ class MarketPriceUpdateOrderOk
         )
     );
 
-    $conn = myself()->_getSelfMysql();
+    $conn = myself()->_getMysql('');
 
     // 1. check order status
     $chk = SqlHelper::selectOne($conn, 't_market_store', array('status'), array('o_link' => $orderId));
diff --git a/webapp/services/callback/MarketSellOrderOk.php b/webapp/services/callback/MarketSellOrderOk.php
index 21fae73a..2daaf986 100644
--- a/webapp/services/callback/MarketSellOrderOk.php
+++ b/webapp/services/callback/MarketSellOrderOk.php
@@ -1,8 +1,12 @@
 <?php
 
 namespace services;
+require_once('MarketCallbackBase.php');
 
-class MarketSellOrderOk
+use services\MarketCallbackBase;
+use phpcommon\SqlHelper;
+
+class MarketSellOrderOk extends MarketCallbackBase
 {
   public function process()
   {
@@ -31,7 +35,7 @@ class MarketSellOrderOk
         )
     );
 
-    $conn = myself()->_getSelfMysql();
+    $conn = myself()->_getMysql('');
 
     // 1. check order status
     $chk = SqlHelper::selectOne($conn, 't_market_store', array('status'), array('o_link' => $orderId));