...
This commit is contained in:
songliang
parent
a458be812e
commit
ae8a42ad24
@ -18,164 +18,204 @@ use services\LogService;
|
|||||||
|
|
||||||
class ShopBuyGoodsDirect
|
class ShopBuyGoodsDirect
|
||||||
{
|
{
|
||||||
public function process()
|
public function process()
|
||||||
{
|
{
|
||||||
error_log("buyGoodsDirect --- " . json_encode($_REQUEST));
|
error_log("buyGoodsDirect --- " . json_encode($_REQUEST));
|
||||||
|
|
||||||
// let repdata = {
|
// let repdata = {
|
||||||
// account_id: string
|
// account_id: string
|
||||||
// order_id: string
|
// order_id: string
|
||||||
// status: string
|
// status: string
|
||||||
// id: string
|
// id: string
|
||||||
// txhash: string
|
// txhash: string
|
||||||
// }
|
// }
|
||||||
// 我返回给你这些数据和一个sign字段,
|
// 我返回给你这些数据和一个sign字段,
|
||||||
// sign使用上面 repdata 按key 顺序排后, 组成key1=val1&key2=val2后, 使用hmac_sha256 hash, key是
|
// sign使用上面 repdata 按key 顺序排后, 组成key1=val1&key2=val2后, 使用hmac_sha256 hash, key是
|
||||||
// PENDING = 0, // 初始状态
|
// PENDING = 0, // 初始状态
|
||||||
// TRANSFERING = 1, //只有国库模式才会有该状态
|
// TRANSFERING = 1, //只有国库模式才会有该状态
|
||||||
// TRANSFERED = 2, //只有国库模式才会有该状态
|
// TRANSFERED = 2, //只有国库模式才会有该状态
|
||||||
// SUCCESS = 9, // 成功的最终状态
|
// SUCCESS = 9, // 成功的最终状态
|
||||||
// TRANSFER_FAIL = 98, // 转账错误
|
// TRANSFER_FAIL = 98, // 转账错误
|
||||||
// FAIL = 99, // 也是错误
|
// FAIL = 99, // 也是错误
|
||||||
//
|
//
|
||||||
|
|
||||||
$account_id = getReqVal('account_id', '');
|
$account_id = getReqVal('account_id', '');
|
||||||
$order_id = getReqVal('order_id', '');
|
$order_id = getReqVal('order_id', '');
|
||||||
$status = getReqVal('status', '');
|
$status = getReqVal('status', '');
|
||||||
$id = getReqVal('id', '');
|
$id = getReqVal('id', '');
|
||||||
$txhash = getReqVal('txhash', '');
|
$txhash = getReqVal('txhash', '');
|
||||||
|
|
||||||
$sign = getReqVal('sign', '');
|
$sign = getReqVal('sign', '');
|
||||||
|
|
||||||
$data = array(
|
$data = array(
|
||||||
'account_id' => $account_id,
|
'account_id' => $account_id,
|
||||||
'id' => $id,
|
'id' => $id,
|
||||||
'order_id' => $order_id,
|
'order_id' => $order_id,
|
||||||
'status' => $status,
|
'status' => $status,
|
||||||
'txhash' => $txhash,
|
'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) {
|
if ($signature != $sign) {
|
||||||
$this->_rspErr(1, "signature error, signature: {$signature}, sign: {$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}");
|
|
||||||
return;
|
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(
|
error_log("buyGoodsDirect-------" . $order_id . "---" . $status);
|
||||||
'goods_id' => $item_id,
|
|
||||||
'goods_num' => $item_num,
|
$conn = myself()->_getMysql('');
|
||||||
'id' => $id,
|
|
||||||
|
$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 _rspErr($errcode, $errmsg)
|
||||||
}
|
{
|
||||||
|
if (SERVER_ENV != _ONLINE) {
|
||||||
private function getAccountId($address)
|
error_log(json_encode(array(
|
||||||
{
|
'errcode' => $errcode,
|
||||||
$row = SqlHelper::ormSelectOne(
|
'errmsg' => $errmsg,
|
||||||
myself()->_getMysql($address),
|
)));
|
||||||
't_user',
|
}
|
||||||
array(
|
echo json_encode(array(
|
||||||
'address' => $address
|
'errcode' => $errcode,
|
||||||
)
|
'errmsg' => $errmsg,
|
||||||
);
|
));
|
||||||
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,
|
|
||||||
)));
|
|
||||||
}
|
}
|
||||||
echo json_encode(array(
|
|
||||||
'errcode' => $errcode,
|
|
||||||
'errmsg' => $errmsg,
|
|
||||||
));
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user