|
|
|
@ -40,16 +40,16 @@ class UserAssetsLogRepository extends BaseRepository |
|
|
|
|
const INTEGRAL_BUY_SHARE = 2; // '分享奖返佣--复购积分', |
|
|
|
|
const INTEGRAL_WITHDRAW_SERVE = 3; // '服务奖返佣--提现积分', |
|
|
|
|
const INTEGRAL_BUY_SERVE = 4; // '服务奖返佣--复购积分', |
|
|
|
|
const INTEGRAL_WITHDRAW_SEND = 5; // '他人转让--提现积分', |
|
|
|
|
const INTEGRAL_WITHDRAW_GET = 6; // '转让他人--提现积分', |
|
|
|
|
const INTEGRAL_WITHDRAW_SEND = 5; // '转让他人--提现积分', |
|
|
|
|
const INTEGRAL_WITHDRAW_GET = 6; // '他人转让--提现积分', |
|
|
|
|
const INTEGRAL_WITHDRAW_DIAMOND = 7; // '兑换钻石--提现积分', |
|
|
|
|
const INTEGRAL_WITHDRAW_HOT = 8; // '爆单奖--提现积分', |
|
|
|
|
const INTEGRAL_BUY_HOT = 9; // '爆单奖--复购积分', |
|
|
|
|
const INTEGRAL_BUY = 10; // '消费--复购积分', |
|
|
|
|
const INTEGRAL_BUY = 10; // '消费--积分', |
|
|
|
|
const INTEGRAL_WITHDRAW = 11; // '提现--提现积分', |
|
|
|
|
|
|
|
|
|
const DIAMOND_SEND = 20; //他人转让 |
|
|
|
|
const DIAMOND_GET = 21; //转让他人 |
|
|
|
|
const DIAMOND_SEND = 20; //转让他人 |
|
|
|
|
const DIAMOND_GET = 21; //他人转让 |
|
|
|
|
const DIAMOND_STOCK = 22; //兑换本票 |
|
|
|
|
const DIAMOND_INTEGRAL = 23; //积分兑换 |
|
|
|
|
const DIAMOND_SHARE = 24; //分享奖返佣 |
|
|
|
@ -96,16 +96,16 @@ class UserAssetsLogRepository extends BaseRepository |
|
|
|
|
self::INTEGRAL_BUY_SHARE => '分享奖返佣--复购积分', |
|
|
|
|
self::INTEGRAL_WITHDRAW_SERVE => '服务奖返佣--提现积分', |
|
|
|
|
self::INTEGRAL_BUY_SERVE => '服务奖返佣--复购积分', |
|
|
|
|
self::INTEGRAL_WITHDRAW_SEND => '他人转让--提现积分', |
|
|
|
|
self::INTEGRAL_WITHDRAW_GET => '转让他人--提现积分', |
|
|
|
|
self::INTEGRAL_WITHDRAW_SEND => '转让他人--提现积分', |
|
|
|
|
self::INTEGRAL_WITHDRAW_GET => '他人转让--提现积分', |
|
|
|
|
self::INTEGRAL_WITHDRAW_DIAMOND => '兑换钻石--提现积分', |
|
|
|
|
self::INTEGRAL_WITHDRAW_HOT => '爆单奖--提现积分', |
|
|
|
|
self::INTEGRAL_BUY_HOT => '爆单奖--复购积分', |
|
|
|
|
self::INTEGRAL_BUY => '消费--复购积分', |
|
|
|
|
self::INTEGRAL_BUY => '消费--积分', |
|
|
|
|
self::INTEGRAL_WITHDRAW => '提现--提现积分', |
|
|
|
|
|
|
|
|
|
self::DIAMOND_SEND => '他人转让', |
|
|
|
|
self::DIAMOND_GET => '转让他人', |
|
|
|
|
self::DIAMOND_SEND => '转让他人', |
|
|
|
|
self::DIAMOND_GET => '他人转让', |
|
|
|
|
self::DIAMOND_STOCK => '兑换本票', |
|
|
|
|
self::DIAMOND_INTEGRAL => '积分兑换', |
|
|
|
|
self::DIAMOND_SHARE => '分享奖返佣', |
|
|
|
@ -143,26 +143,38 @@ class UserAssetsLogRepository extends BaseRepository |
|
|
|
|
if ($item) { |
|
|
|
|
$item->status = self::STATUS_REFUND; |
|
|
|
|
$item->save(); |
|
|
|
|
$this->userAssetsRepository->updateAssets($orderItem['uid'], $item['ext']); |
|
|
|
|
} |
|
|
|
|
$this->userAssetsRepository->updateAssets($orderItem['uid'], array('integral_buy' => -1 * $item['count'])); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public function userPayEvent($groupOrder) |
|
|
|
|
{ |
|
|
|
|
$assets = $this->userAssetsRepository->assets($groupOrder['uid']); |
|
|
|
|
foreach ($groupOrder['orderList'] as $orderItem) { |
|
|
|
|
|
|
|
|
|
// 5. 本人使用的福利积分 |
|
|
|
|
if ($orderItem['integral']) { |
|
|
|
|
$updateData = array('integral_buy' => 0, 'integral_withdraw' => 0); |
|
|
|
|
if ($orderItem['integral'] > $assets['integral_buy']) { |
|
|
|
|
$updateData['integral_buy'] = $assets['integral_buy']; |
|
|
|
|
$updateData['integral_withdraw'] = $orderItem['integral'] - $assets['integral_buy']; |
|
|
|
|
} else { |
|
|
|
|
$updateData['integral_buy'] = $orderItem['integral']; |
|
|
|
|
} |
|
|
|
|
$log = array('uid' => $orderItem['uid'], |
|
|
|
|
'asset_type' => self::ASSET_INTEGRAL, |
|
|
|
|
'type' => self::INTEGRAL_BUY, |
|
|
|
|
'status' => self::STATUS_BUY, |
|
|
|
|
'order_id' => $orderItem['order_id'], |
|
|
|
|
'count' => -$orderItem['integral'], |
|
|
|
|
'ext' => $updateData, |
|
|
|
|
); |
|
|
|
|
$this->addLog([$log]); |
|
|
|
|
$this->userAssetsRepository->updateAssets($orderItem['uid'], array('integral_buy' => -$orderItem['integral'])); |
|
|
|
|
foreach ($updateData as $key => $value){ |
|
|
|
|
$assets[$key] -= $value; |
|
|
|
|
} |
|
|
|
|
$this->userAssetsRepository->updateAssets($orderItem['uid'], $updateData, false); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
@ -374,16 +386,16 @@ class UserAssetsLogRepository extends BaseRepository |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
// 计算每个购买当前爆单商品的积分数据 |
|
|
|
|
$profit = $productItem['total_price'] - $productItem['cost'] * $productItem['product_num']; |
|
|
|
|
$where = array(); |
|
|
|
|
$profit = $productItem['total_price'] - $productItem['cost'] * $productItem['product_num']; |
|
|
|
|
$where = array(); |
|
|
|
|
// $where[] = array('product_id', '=', $productItem['product_id']); |
|
|
|
|
$list = $hotRepository->getList($where); |
|
|
|
|
$list = $hotRepository->getList($where); |
|
|
|
|
|
|
|
|
|
$logList = array(); |
|
|
|
|
foreach ($list as $item) { |
|
|
|
|
$tmp = $this->_getIntegral($profit * $product['hot_integral_rate'] / 100 / count($list)); |
|
|
|
|
if ($item['total'] - $item['current'] < $tmp['integral_buy'] + $tmp['integral_withdraw']) { |
|
|
|
|
$tmp = $this->_getIntegral($item['total'] - $item['current']); |
|
|
|
|
$tmp = $this->_getIntegral($item['total'] - $item['current']); |
|
|
|
|
// $item['status'] = 1; |
|
|
|
|
} |
|
|
|
|
$this->userAssetsRepository->updateAssets($item['uid'], $tmp); |
|
|
|
|