172 lines
4.8 KiB
PHP
172 lines
4.8 KiB
PHP
<?php
|
|
|
|
namespace services;
|
|
|
|
require_once("mt/ShopGoods.php");
|
|
require_once("mt/Item.php");
|
|
|
|
require_once("models/ShopBuyRecord.php");
|
|
require_once("models/OutAppOrder.php");
|
|
|
|
require_once("services/LogService.php");
|
|
require_once("ShopAddItemService.php");
|
|
|
|
use phpcommon\SqlHelper;
|
|
|
|
use mt\ShopGoods;
|
|
use mt\Item;
|
|
|
|
use models\ShopBuyRecord;
|
|
use models\OutAppOrder;
|
|
|
|
use services\LogService;
|
|
|
|
/*
|
|
// 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, // 也是错误
|
|
//
|
|
*/
|
|
|
|
class OutAppPurchase {
|
|
|
|
public function process()
|
|
{
|
|
error_log("OutAppPurchase --- " . json_encode($_REQUEST));
|
|
|
|
if (!$this->verifySign()) {
|
|
error_log("verifySign error --- " . json_encode($_REQUEST));
|
|
myself()->_rspErr(1, 'verifySign error');
|
|
return;
|
|
}
|
|
$accountId = getReqVal('account_id', '');
|
|
$status = getReqVal('status', '');
|
|
$id = getReqVal('id', '');
|
|
$txhash = getReqVal('txhash', '');
|
|
$sign = getReqVal('sign', '');
|
|
$orderId = getReqVal('order_id', '');
|
|
|
|
$orderDb = OutAppOrder::find($orderId);
|
|
if (!$orderDb) {
|
|
myself()->_rspErr(2, 'not found order');
|
|
return;
|
|
}
|
|
if ($orderDb['status'] != OutAppOrder::FINISHED_STATE) {
|
|
myself()->_rspErr(0, 'order is finished');
|
|
return;
|
|
}
|
|
OutAppOrder::markFinished($orderDb['order_id']);
|
|
$orderDb = OutAppOrder::find($orderId);
|
|
if (!$orderDb) {
|
|
myself()->_rspErr(2, 'not found order');
|
|
return;
|
|
}
|
|
if ($orderDb['status'] == OutAppOrder::FINISHED_STATE) {
|
|
myself()->_rspErr(0, 'order is finished');
|
|
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;
|
|
}
|
|
|
|
if ($buyStatus == 2) {
|
|
$this->_rspErr(2, "buyStatus error, buyStatus: {$buyStatus}");
|
|
return;
|
|
}
|
|
|
|
// 以下是看商品表中是否配置了充值额外奖励
|
|
$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) {
|
|
if ($item_id == V_ITEM_DIAMOND) {
|
|
$event = [
|
|
'name' => LogService::RECHARGE_CEBG_BONUS,
|
|
'val' => $item_num
|
|
];
|
|
LogService::productDiamondCallback(
|
|
array(
|
|
'account_id' => $orderDb['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 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 verifySign()
|
|
{
|
|
|
|
}
|
|
|
|
}
|