<?php

namespace services;

require_once('phpcommon/bchelper.php');
require_once ('services/callback/BuyPassCbService.php');
require_once ('services/callback/BuyShopGoodsCbService.php');

use phpcommon\SqlHelper;

class GameItemMallBuyOk {

    public function process()
    {
        $address = getReqVal('address', '');
        $orderId = getReqVal('orderId', '');
error_log("GameItemMallBuyOk1:process");

        $orderDb = SqlHelper::ormSelectOne(
            myself()->_getMysql($address),
            't_bc_order',
            array(
                'order_id' => $orderId
            )
        );
        error_log("GameItemMallBuyOk2:select order");
        //1：已发货 2：订单不存在
        if (!$orderDb){
            error_log("GameItemMallBuyOk2-1:订单不存在");
            return json_encode(array(
                'errcode' => 2,
                'errmsg' => "Order does not exist",
            ));
        }
        if ($orderDb['status'] == 1){
            error_log("GameItemMallBuyOk2-2:订单已发货");
            return json_encode(array(
                'errcode' => 1,
                'errmsg' => "Order shipped",
            ));
        }
        error_log("GameItemMallBuyOk2-3:updateOrderState begin");
//         修改订单状态
        $this->_updateOrderState($address,$orderId);

//        小胡 回调的处理
        if ($this->_isVirtualItem($orderDb['item_id'])){
            $passCbService = new BuyPassCbService();
            error_log("GameItemMallBuyOk3:小胡");
            $passCbService->process($orderDb);
        } else {
//        老宋 处理...
            $shopGoodsCbService = new BuyShopGoodsCbService();
            $shopGoodsCbService->process($orderDb);

        }
        return json_encode(array(
            'errcode' => 0,
            'errmsg' => "callback success",
        ));
    }

    private function _isVirtualItem($itemId){
        return in_array($itemId, array(V_ITEM_EXP, V_ITEM_PASS));
    }

    private function _updateOrderState($address,$transId){
        error_log("GameItemMallBuyOk2-4:updateOrderState");
        SqlHelper::update
        (myself()->_getMysql($address),
            't_bc_order',
            array(
                'order_id' => $transId
            ),
            array(
                'status' => 1,
                'modifytime' => myself()->_getNowTime(),
            )
        );
    }

}