game2006api/webapp/services/callback/IutAppPurchase.php

<?php

namespace services;

require_once("mt/ShopGoods.php");
require_once("mt/Item.php");
require_once("models/ShopBuyRecord.php");
require_once("services/LogService.php");
require_once("ShopAddItemService.php");

use phpcommon\SqlHelper;

use mt\ShopGoods;
use mt\Item;
use models\ShopBuyRecord;

use services\LogService;

class OutAppPurchase {

    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,	// 也是错误
        // 

        $account_id = getReqVal('account_id', '');
        $order_id = getReqVal('order_id', '');
        $status = getReqVal('status', '');
        $id = getReqVal('id', '');
        $txhash = getReqVal('txhash', '');

        $sign = getReqVal('sign', '');

        $data = array(
            'account_id' => $account_id,
            'id' => $id,
            'order_id' => $order_id,
            'status' => $status,
            'txhash' => $txhash,
        );

        $hash_data = http_build_query($data);

        $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('order_id' => $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('order_id' => $order_id), array('status' => $buyStatus));

        if ($buyStatus == 2) {
            $this->_rspErr(2, "buyStatus error, buyStatus: {$buyStatus}");
            return;
        }

        // 以下是看商品表中是否配置了充值额外奖励
        $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::productDiamondCallback(['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",
        ));
    }

    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,
        ));
    }
}