diff --git a/webapp/services/callback/ShopBuyGoodsDirect.php b/webapp/services/callback/ShopBuyGoodsDirect.php
index 43a78e37..8f4f08d2 100644
--- a/webapp/services/callback/ShopBuyGoodsDirect.php
+++ b/webapp/services/callback/ShopBuyGoodsDirect.php
@@ -18,164 +18,204 @@ use services\LogService;
 
 class ShopBuyGoodsDirect
 {
-  public function process()
-  {
-    error_log("buyGoodsDirect --- " . json_encode($_REQUEST));
+    public function process()
+    {
+        error_log("buyGoodsDirect --- " . json_encode($_REQUEST));
 
-    // let repdata = {
-    //     account_id: string
-    //     order_id: string
-    //     status: string
-    //     id: string
-    //     txhash: string
-    //   }
-    // 我返回给你这些数据和一个sign字段, 
-    // sign使用上面 repdata 按key 顺序排后, 组成key1=val1&key2=val2后, 使用hmac_sha256 hash, key是 
-    // PENDING = 0,	// 初始状态
-    // TRANSFERING = 1, //只有国库模式才会有该状态
-    // TRANSFERED = 2, //只有国库模式才会有该状态
-    // SUCCESS = 9,		// 成功的最终状态
-    // TRANSFER_FAIL = 98, // 转账错误
-    // FAIL = 99,	// 也是错误
-    // 
+        // let repdata = {
+        //     account_id: string
+        //     order_id: string
+        //     status: string
+        //     id: string
+        //     txhash: string
+        //   }
+        // 我返回给你这些数据和一个sign字段, 
+        // sign使用上面 repdata 按key 顺序排后, 组成key1=val1&key2=val2后, 使用hmac_sha256 hash, key是 
+        // PENDING = 0,	// 初始状态
+        // TRANSFERING = 1, //只有国库模式才会有该状态
+        // TRANSFERED = 2, //只有国库模式才会有该状态
+        // SUCCESS = 9,		// 成功的最终状态
+        // TRANSFER_FAIL = 98, // 转账错误
+        // FAIL = 99,	// 也是错误
+        // 
 
-    $account_id = getReqVal('account_id', '');
-    $order_id = getReqVal('order_id', '');
-    $status = getReqVal('status', '');
-    $id = getReqVal('id', '');
-    $txhash = getReqVal('txhash', '');
+        $account_id = getReqVal('account_id', '');
+        $order_id = getReqVal('order_id', '');
+        $status = getReqVal('status', '');
+        $id = getReqVal('id', '');
+        $txhash = getReqVal('txhash', '');
 
-    $sign = getReqVal('sign', '');
+        $sign = getReqVal('sign', '');
 
-    $data = array(
-        'account_id' => $account_id,
-        'id' => $id,
-        'order_id' => $order_id,
-        'status' => $status,
-        'txhash' => $txhash,
-    );
+        $data = array(
+            'account_id' => $account_id,
+            'id' => $id,
+            'order_id' => $order_id,
+            'status' => $status,
+            'txhash' => $txhash,
+        );
 
-    $hash_data = http_build_query($data);
+        $hash_data = http_build_query($data);
 
-    $signature = hash_hmac('sha256', $hash_data, BUY_SERVER_PKEY);
+        $signature = hash_hmac('sha256', $hash_data, BUY_SERVER_PKEY);
 
-    if ($signature != $sign) {
-        $this->_rspErr(1, "signature error, signature: {$signature}, sign: {$sign}");
-        return;
-    }
-
-    error_log("buyGoodsDirect-------" . $order_id . "---" . $status);
-
-    $conn = myself()->_getMysql('');
-
-    $order = SqlHelper::selectOne($conn, 't_shop_buy_order', array('address', 'id', 'item_id', 'goods_num', 'status'), array('idx' => $order_id));
-    if (!$order) {
-        $this->_rspErr(2, "order not found: {$order_id}");
-        return;
-    }
-
-    $id = $order['id'];
-    $goods_num = $order['goods_num'];
-    $o_status = $order['status'];
-
-    if ($o_status != 0) {
-        $this->_rspErr(1, "order status error, status: {$o_status}");
-        return;
-    }
-
-    $buyStatus = 0; // 1: 成功, 2: 失败
-    switch ($status) {
-        case "9":
-            $buyStatus = 1;
-            break;
-        case "99":
-        case "98":
-            $buyStatus = 2;
-            break;
-        default:
-            error_log("buyGoodsDirect-------" . $order_id . "---" . $status);
-            $this->_rspErr(1, "status error, status: {$status}");
+        if ($signature != $sign) {
+            $this->_rspErr(1, "signature error, signature: {$signature}, sign: {$sign}");
             return;
-    }
-
-    SqlHelper::update($conn, 't_shop_buy_order', array('idx' => $order_id), array('status' => $buyStatus));
-
-    // 以下是看商品表中是否配置了充值额外奖励
-    $goods = ShopGoods::get($id);
-    $goods_num = $order['goods_num'];
-    $bundle_size = $goods['bonus_num'] ? $goods['bonus_num'] : 0;
-    $item_num = $goods_num * $bundle_size;
-    $item_id = $goods['bonus'];
-    $meta = Item::get($item_id);
-    if ($meta && $item_num > 0) {
-        $address = $order['address'];
-        $account_id = $this->getAccountId($address);
-
-        if ($item_id == V_ITEM_DIAMOND) {
-            $event = [
-                'name' => LogService::RECHARGE_CEBG_BONUS,
-                'val' => $item_num
-            ];
-            LogService::productDiamond(['account_id' => $account_id], $event);
         }
 
-        $this->_addGoods($address, array(
-            'goods_id' => $item_id,
-            'goods_num' => $item_num,
-            'id' => $id,
+        error_log("buyGoodsDirect-------" . $order_id . "---" . $status);
+
+        $conn = myself()->_getMysql('');
+
+        $order = SqlHelper::selectOne($conn, 't_shop_buy_order', array('address', 'id', 'item_id', 'goods_num', 'status'), array('idx' => $order_id));
+        if (!$order) {
+            $this->_rspErr(2, "order not found: {$order_id}");
+            return;
+        }
+
+        $id = $order['id'];
+        $goods_num = $order['goods_num'];
+        $o_status = $order['status'];
+        $address = $order['address'];
+
+        if ($o_status != 0) {
+            $this->_rspErr(1, "order status error, status: {$o_status}");
+            return;
+        }
+
+        $buyStatus = 0; // 1: 成功, 2: 失败
+        switch ($status) {
+            case "9":
+                $buyStatus = 1;
+                // 充值成功，开始首充奖励
+                $this->beginFirstTupop($address);
+                break;
+            case "99":
+            case "98":
+                $buyStatus = 2;
+                break;
+            default:
+                error_log("buyGoodsDirect--- " . $order_id . " --- " . $status);
+                $this->_rspErr(1, "status error, status: {$status}");
+                break;
+        }
+
+        SqlHelper::update($conn, 't_shop_buy_order', array('idx' => $order_id), array('status' => $buyStatus));
+
+        // 以下是看商品表中是否配置了充值额外奖励
+        $goods = ShopGoods::get($id);
+        error_log("buyGoodsDirect---" . json_encode($goods));
+        $goods_num = $order['goods_num'];
+        $bundle_size = $goods['bonus_num'] ? $goods['bonus_num'] : 0;
+        $item_num = $goods_num * $bundle_size;
+        $item_id = $goods['bonus'];
+        $meta = Item::get($item_id);
+        error_log("buyGoodsDirect---" . $item_id . "---" . $item_num . "---" . $bundle_size . "---" . $meta['name']);
+        if ($meta && $item_num > 0) {
+            // $address = $order['address'];
+            $account_id = $this->getAccountId($address);
+
+            if ($item_id == V_ITEM_DIAMOND) {
+                $event = [
+                    'name' => LogService::RECHARGE_CEBG_BONUS,
+                    'val' => $item_num
+                ];
+                LogService::productDiamond(['account_id' => $account_id], $event);
+            }
+
+            error_log("buyGoodsDirect---" . $address . "---" . $item_id . "---" . $item_num);
+
+            $this->_addGoods($address, array(
+                'goods_id' => $item_id,
+                'goods_num' => $item_num,
+                'id' => $id,
+            ));
+        }
+
+        $this->_rspOk();
+    }
+
+    private function getAccountId($address)
+    {
+        $row = SqlHelper::ormSelectOne(
+            myself()->_getMysql($address),
+            't_user',
+            array(
+                'address' => $address
+            )
+        );
+        return $row['account_id'];
+    }
+
+    private function _addGoods($address, $goods)
+    {
+        $itemService = new ShopAddItemService();
+        $item_id = $goods['goods_id'];
+        $goods_num = $goods['goods_num'];
+
+        $id = null;
+        if ($goods['id']) {
+            $id = $goods['id'];
+        }
+
+        error_log('_addGoods ' . $address . ' item_id ' . $item_id . ' goods_num ' . $goods_num . ' id ' . $id);
+        $itemService->addItem($address, $item_id, $goods_num);
+        if ($id) {
+            ShopBuyRecord::addWithAddress($address, $id, $goods_num);
+        }
+    }
+
+    private function beginFirstTupop($address)
+    {
+        $conn = myself()->_getMysql('');
+
+        $exist = SqlHelper::selectOne(
+            $conn,
+            't_first_topup',
+            array('address'),
+            array('address' => $address)
+        );
+        if ($exist) {
+            return;
+        }
+
+        // 开始首充奖励活动进程
+        $chk = SqlHelper::insert(
+            $conn,
+            't_first_topup',
+            array(
+                'address' => $address,
+                'createtime' => myself()->_getNowTime(),
+                'status1' => 0,
+                'status2' => 0,
+                'status3' => 0,
+            )
+        );
+        if (!$chk) {
+            return;
+        }
+    }
+
+    private function _rspOk()
+    {
+        echo json_encode(array(
+            'errcode' => 0,
+            'errmsg' => "callback success",
         ));
     }
 
-    $this->_rspOk();
-  }
-
-  private function getAccountId($address)
-  {
-      $row = SqlHelper::ormSelectOne(
-          myself()->_getMysql($address),
-          't_user',
-          array(
-              'address' => $address
-          )
-      );
-      return $row['account_id'];
-  }
-
-  private function _addGoods($address, $goods)
-  {
-      $itemService = new ShopAddItemService();
-      $item_id = $goods['goods_id'];
-      $goods_num = $goods['goods_num'];
-
-      $id = null;
-      if ($goods['id']) {
-          $id = $goods['id'];
-      }
-
-      error_log('_addGoods ' . $address . ' item_id ' . $item_id . ' goods_num ' . $goods_num . ' id ' . $id);
-      $itemService->addItem($address, $item_id, $goods_num);
-      if ($id) {
-          ShopBuyRecord::addWithAddress($address, $id, $goods_num);
-      }
-  }
-
-  private function _rspOk() {
-    echo json_encode(array(
-      'errcode' => 0,
-      'errmsg' => "callback success",
-    ));
-  }
-
-  private function _rspErr($errcode, $errmsg) {
-    if (SERVER_ENV != _ONLINE) {
-      error_log(json_encode(array(
-        'errcode' => $errcode,
-        'errmsg' => $errmsg,
-      )));
+    private 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,
+        ));
     }
-    echo json_encode(array(
-      'errcode' => $errcode,
-      'errmsg' => $errmsg,
-    ));
-  }
 }