shenying/app/jobs/integral/IntegralJob.php

<?php

namespace app\jobs\integral;

use app\services\user\level\UserLevelServices;
use app\services\user\UserAwardIntegralServices;
use app\services\user\UserBillServices;
use app\services\user\UserBrokerageServices;
use app\services\user\UserMoneyServices;
use app\services\user\UserServices;
use crmeb\basic\BaseJobs;
use crmeb\traits\QueueTrait;
use think\facade\Log;

/**
 * 订单消息队列
 * Class OrderJob
 * @package app\jobs
 */
class IntegralJob extends BaseJobs
{
    use QueueTrait;

    public function dealOrderIntegral($order)
    {
        Log::debug(date('Y-m-d H:i:s') . '开始处理' . $order['id'] . '积分');
        /** @var UserAwardIntegralServices $awardIntegralService */
        $awardIntegralService = app()->make(UserAwardIntegralServices::class);
        /** @var UserServices $userService */
        $userService = app()->make(UserServices::class);
        /** @var UserLevelServices $levelServices */
        $levelServices = app()->make(UserLevelServices::class);
        $user = $userService->getUserInfo($order['uid']);
        $integral_price = $awardIntegralService->getPrice($order['id']);
        $total_price = $order['total_price'];
        $award_price = bcsub($total_price, $order['cost'], 2);
        return $awardIntegralService->transaction(function () use ($award_price, $levelServices, $awardIntegralService, $userService, $user, $integral_price, $total_price, $order) {
            try {
                //添加静态积分
                $static_integral_ratio = sys_config('static_integral_ratio', 0);
                $give_static_integral = bcdiv(bcmul($total_price, $static_integral_ratio), 100, 2);
//                if ($give_static_integral > 0) {
                $rate = sys_config('static_integral_rate', 3);
                $extract_sum = bcmul($total_price, $rate, 2);
                $mark = '购买商品，获得消费分';
                $awardIntegralService->incIntegral($order['uid'], $integral_price, $give_static_integral, $total_price, 0, $extract_sum, $order['id'], $mark);
//                }
                //添加奖池
                $lake_ratio = sys_config('lake_ratio', 0);
                $add_lake = bcdiv(bcmul($award_price, $lake_ratio), 100, 2);
                if ($add_lake > 0) {
                    $mark = '用户' . $order['uid'] . '购买商品，添加资金池';
                    $awardIntegralService->addLake($add_lake, $order['id'], $mark);
                }
                //TODO 加动态积分
                //推荐奖
                $rate = sys_config('action_integral_rate', 3);
                $spread = $userService->getUserInfo($user['spread_uid']);
                if ($spread) {
                    if ($awardIntegralService->getPaySum($spread['uid']) >= 1000 || $awardIntegralService->getHourExtractPaySum($spread['uid'], 24) >= 1000) {
                        $award_ratio = sys_config('recommend_integral', 0);
                        if ($awardIntegralService->reOrder($user['uid'], $order['id'])) {
                            $award_ratio = sys_config('reorder_recommend_integral', 0);
                        }
                        $give_action_integral = bcdiv(bcmul($total_price, $award_ratio), 100, 2);
                        if ($give_action_integral > 0) {
                            $extract_sum = bcmul($give_action_integral, $rate, 2);
                            $mark = '推荐用户' . $user['nickname'] . "({$user['uid']})" . '购买商品，获得推荐积分';
                            $awardIntegralService->incIntegral($spread['uid'], $integral_price, $give_action_integral, $total_price, 1, $extract_sum, $order['id'], $mark);
                        }
                    }
                    if ($awardIntegralService->getPaySum($spread['uid']) > 0) {
                        $award_ratio = sys_config('recommend_speed_integral', 0);
                        $give_action_integral = bcdiv(bcmul($total_price, $award_ratio), 100, 2);
                        if ($give_action_integral > 0) {
                            $first = $awardIntegralService->getFirstStaticIntegral($spread['uid']);
                            if ($first) {
                                $mark = '，推荐用户' . $user['nickname'] . "({$user['uid']})" . '购买商品，获得加速积分';
                                $awardIntegralService->incUpdateIntegral($first['id'], $integral_price, $give_action_integral, $mark);
                            }
                        }
                    }
                }
                $levelServices->detection((int)$user['uid']);
                $pass = [$user['uid']];
                $send = 0;
                while ($spread && !in_array($spread['uid'], $pass)) {
                    //先发奖，再结算等级
                    $level = $levelServices->getUserLevel($spread['uid']);
                    $ratio = $level['levelInfo']['group_award'] ?? 0;
                    $give_action_integral = bcdiv(bcmul($total_price, $ratio), 100, 2);
                    if ($give_action_integral > $send) {
                        $real_send = bcsub($give_action_integral, $send, 2);
                        if ($awardIntegralService->getPaySum($spread['uid']) >= 0 || $awardIntegralService->getHourExtractPaySum($spread['uid'], 24) > 0 || $spread['award_switch']) {
                            $extract_sum = bcmul($real_send, $rate, 2);
                            $mark = '团队用户' . $user['nickname'] . "({$user['uid']})" . '购买商品，获得团队级差积分';
                            $awardIntegralService->incIntegral($spread['uid'], $integral_price, $real_send, $total_price, 1, $extract_sum, $order['id'], $mark);
                        }
                        $send = $give_action_integral;
                    }
                    $levelServices->detection((int)$spread['uid']);
                    $pass[] = $spread['uid'];
                    $spread = $userService->getUserInfo($spread['spread_uid']);
                }
                $this->autoExtract($awardIntegralService->getPrice());
                Log::debug(date('Y-m-d H:i:s') . '结束处理' . $order['id'] . '积分');
                return true;
            } catch (\Throwable $e) {
                Log::error('处理积分奖池失败,失败原因:' . $e->getMessage());
                Log::debug(date('Y-m-d H:i:s') . '结束处理' . $order['id'] . '积分');
                return false;
            }
        });

    }


    public function extract($id)
    {
        /** @var UserAwardIntegralServices $awardIntegralService */
        $awardIntegralService = app()->make(UserAwardIntegralServices::class);
        /** @var UserBrokerageServices $brokerageService */
        $brokerageService = app()->make(UserBrokerageServices::class);
        /** @var UserBillServices $billService */
        $billService = app()->make(UserBillServices::class);
        /** @var UserServices $userService */
        $userService = app()->make(UserServices::class);
        $info = $awardIntegralService->getIntegral($id);
        return $awardIntegralService->transaction(function () use ($info, $awardIntegralService, $brokerageService, $billService, $userService) {
            if ($info['status'] != 0) {
                $awardIntegralService->update($info['id'], ['handle' => 0]);
                return true;
            }
            $price = $awardIntegralService->getPrice();
            $sum = bcmul($price, $info['num'], 2);
            if ($sum > $info['extract_sum']) {
                $sum = $info['extract_sum'];
            }
            $res = true;
            $extract_ratio = sys_config('extract_ratio', 0);
            if ($info['type'] == 1) $extract_ratio = sys_config('extract_ratio_active', 0);
            $real_out = bcdiv(bcmul($sum, $extract_ratio), 100, 2);
            if ($real_out > 0) {
                $user = $userService->getUserInfo($info['uid']);
                $mark = '用户积分出局，出局时价格' . $price;
                $res = $res && $awardIntegralService->addLake(-$real_out, $info['id'], $mark);

                $to_brokerage = bcdiv(bcmul($real_out, sys_config('extract_brokerage_ratio', 0)), 100, 2);
                $balance = bcadd($user['brokerage_price'], $to_brokerage, 2);
                $res = $res && $brokerageService->income('extract_integral', $info['uid'], [
                        'type' => $info['type'] ? '贡献分' : '消费分',
                        'price' => round($price, 2),
                        'integral_num' => $info['num'],
                        'number' => floatval($to_brokerage),
                        'frozen_time' => 0
                    ], $balance, $info['id']);
                // 添加用户佣金
                $res = $res && $userService->bcInc($info['uid'], 'brokerage_price', $to_brokerage, 'uid');

                $to_energy = bcsub($real_out, $to_brokerage, 2);
                $balance = bcadd($user['energy'], $to_energy, 2);
                $res = $res && $billService->income('extract_integral', $info['uid'], [
                        'type' => $info['type'] ? '贡献分' : '消费分',
                        'price' => round($price, 2),
                        'integral_num' => $info['num'],
                        'number' => floatval($to_energy),
                    ], $balance, $info['id']);
                // 添加用户佣金
                $res = $res && $userService->bcInc($info['uid'], 'energy', $to_energy, 'uid');

                $res = $res && $awardIntegralService->update($info['id'], ['handle' => 0, 'extract_sum_real' => $sum, 'status' => 1, 'extract_time' => time()]);
            }
            return $res && $this->autoExtract($awardIntegralService->getPrice());
        });
    }


    public function autoExtract($price)
    {
        /** @var UserAwardIntegralServices $awardIntegralService */
        $awardIntegralService = app()->make(UserAwardIntegralServices::class);
        /** @var UserBrokerageServices $brokerageService */
        $brokerageService = app()->make(UserBrokerageServices::class);
        /** @var UserMoneyServices $moneyService */
        $moneyService = app()->make(UserMoneyServices::class);
        /** @var UserBillServices $billService */
        $billService = app()->make(UserBillServices::class);
        /** @var UserServices $userService */
        $userService = app()->make(UserServices::class);
        $infos = $awardIntegralService->getIntegralsOverExtract($price);
        $res = true;
        foreach ($infos as $info) {
            if ($info['status'] != 0) {
                $awardIntegralService->update($info['id'], ['handle' => 0]);
                continue;
            }
            $sum = bcmul($price, $info['num'], 2);
            if ($sum > $info['extract_sum']) {
                $sum = $info['extract_sum'];
            }
            $extract_ratio = sys_config('extract_ratio', 0);
            if ($info['type'] == 1) $extract_ratio = sys_config('extract_ratio_active', 0);
            $real_out = bcdiv(bcmul($sum, $extract_ratio), 100, 2);
            $left = bcsub($info['num'], bcdiv(bcmul($info['num'], $extract_ratio), 100, 2), 5);
            $to_top = bcdiv(bcmul($left, sys_config('extract_speed_ratio', 0)), 100, 5);
            $extract_speed_num = sys_config('extract_speed_num', 0);
            if ($extract_speed_num > 0) {
                $to_top = bcdiv($to_top, $extract_speed_num, 5);
            } else {
                $to_top = 0;
            }
            $to_spread = 0;
            if ($info['type'] == 0) {
                $to_spread = bcdiv(bcmul($info['num'], sys_config('extract_spread_ratio', 0)), 100, 2);
            }
            $user = $userService->getUserInfo($info['uid']);
            if ($real_out > 0) {
                $mark = '用户积分出局，出局时价格' . $price;
                $res = $res && $awardIntegralService->addLake(-$real_out, $info['id'], $mark);

                $to_now_money = 0;
                $starts_return_time = sys_config('starts_return_time', 0);
                if ($starts_return_time > 0) {
                    $count = $awardIntegralService->search(['uid' => $user['uid'], 'type' => 0, 'status' => 1])->count();
                    if ($count < $starts_return_time) {
                        $to_now_money = $info['order_price'];
                        if ($to_now_money > $real_out) {
                            $to_now_money = $real_out;
                        }
                        $real_out = bcsub($real_out, $to_now_money, 2);
                    }
                }

                if ($to_now_money > 0) {
                    $balance = bcadd($user['now_money'], $to_now_money, 2);
                    $res = $res && $moneyService->income('extract_integral', $info['uid'], [
                            'type' => $info['type'] ? '贡献分' : '消费分',
                            'price' => round($price, 2),
                            'integral_num' => $info['num'],
                            'number' => floatval($to_now_money),
                            'frozen_time' => 0
                        ], $balance, $info['id']);
                    // 添加用户佣金
                    $res = $res && $userService->bcInc($info['uid'], 'now_money', $to_now_money, 'uid');
                }

                $to_brokerage = bcdiv(bcmul($real_out, sys_config('extract_brokerage_ratio', 0)), 100, 2);
                if ($to_brokerage > 0) {
                    $balance = bcadd($user['brokerage_price'], $to_brokerage, 2);
                    $res = $res && $brokerageService->income('extract_integral', $info['uid'], [
                            'type' => $info['type'] ? '贡献分' : '消费分',
                            'price' => round($price, 2),
                            'integral_num' => $info['num'],
                            'number' => floatval($to_brokerage),
                            'frozen_time' => 0
                        ], $balance, $info['id']);
                    // 添加用户佣金
                    $res = $res && $userService->bcInc($info['uid'], 'brokerage_price', $to_brokerage, 'uid');
                }

                $to_energy = bcsub($real_out, $to_brokerage, 2);
                if ($to_energy > 0) {
                    $balance = bcadd($user['energy'], $to_energy, 2);
                    $res = $res && $billService->income('extract_integral', $info['uid'], [
                            'type' => $info['type'] ? '贡献分' : '消费分',
                            'price' => round($price, 2),
                            'integral_num' => $info['num'],
                            'number' => floatval($to_energy),
                        ], $balance, $info['id']);
                    // 添加用户佣金
                    $res = $res && $userService->bcInc($info['uid'], 'energy', $to_energy, 'uid');
                }
                $res = $res && $awardIntegralService->update($info['id'], ['handle' => 0, 'extract_sum_real' => $sum, 'status' => 1, 'extract_time' => time()]);
            }
            if ($to_top > 0) {
                $id = 0;
                for ($i = 0; $i < $extract_speed_num; $i++) {
                    $first = $awardIntegralService->getTopStaticIntegral($id);
                    if ($first) {
                        $mark = '，用户' . $user['nickname'] . "({$user['uid']})" . '积分出局，获得加速积分';
                        $awardIntegralService->incUpdateIntegral($first['id'], 0, $to_top, $mark);
                    } else {
                        break;
                    }
                    $id = $first['id'];
                }
            }
            if ($to_spread > 0) {
                $spread = $userService->getUserInfo($user['spread_uid']);
                if ($spread) {
                    $first = $awardIntegralService->getFirstStaticIntegral($spread['uid']);
                    if ($first) {
                        $mark = '，推荐用户' . $user['nickname'] . "({$user['uid']})" . '消费分出局，获得加速积分';
                        $awardIntegralService->incUpdateIntegral($first['id'], 0, $to_spread, $mark);
                    }
                }
            }
        }
        if (count($infos) > 0) return $res && $this->autoExtract($awardIntegralService->getPrice());
        return $res;
    }

    /**
     * 减积分
     * @param int $uid 用户
     * @param float $static 静态积分
     * @param float $action 动态积分
     * @param float $cash 资金池
     * @param int $link_id 关联ID
     * @param string $mark 备注
     */
    public function decIntegral(int $uid, float $static, float $action, float $cash, int $link_id = 0, string $mark = '')
    {

    }


}