NN2026041601/app/Services/Api/SettleService.php

<?php
// +----------------------------------------------------------------------
// | LARAVEL8.0 框架 [ LARAVEL ][ RXThinkCMF ]
// +----------------------------------------------------------------------
// | 版权所有 2017~2021 LARAVEL研发中心
// +----------------------------------------------------------------------
// | 官方网站: http://www.laravel.cn
// +----------------------------------------------------------------------
// | Author: laravel开发员 <laravel.qq.com>
// +----------------------------------------------------------------------

namespace App\Services\Api;

use App\Models\AccountLogModel;
use App\Models\CouponModel;
use App\Models\MemberCouponModel;
use App\Models\MemberModel;
use App\Models\OrderCommissionModel;
use App\Models\StoreModel;
use App\Services\BaseService;
use App\Services\Common\MemberLevelService;
use App\Services\ConfigService;
use App\Services\RedisService;
use Illuminate\Support\Facades\DB;

/**
 * 结算管理-服务类
 * @author laravel开发员
 * @since 2020/11/11
 * @package App\Services\Api
 */
class SettleService extends BaseService
{
    /**
     * 构造函数
     * @author laravel开发员
     * @since 2020/11/11
     */
    public function __construct()
    {
        $this->model = new AccountLogModel();
    }

    /**
     * 静态入口
     * @return static|null
     */
    public static function make()
    {
        if (!self::$instance) {
            self::$instance = (new static());
        }
        return self::$instance;
    }

    /**
     * 商家收益结算
     * @param $storeId
     * @param $money 收益
     * @param $order 订单数据
     * @return array|false|int
     */
    public function storeBonus($storeId, $money, $order)
    {
        $orderNo = isset($order['order_no'])? $order['order_no'] : '';
        if($money<=0 && $storeId<=0){
            $this->error = '无企业佣金可结算';
            return false;
        }

        $storeInfo = StoreModel::where(['id'=> $storeId,'mark'=>1])->first();
        $balance = isset($storeInfo['bonus_total'])? $storeInfo['bonus_total'] : 0;
        $storeUserId = isset($storeInfo['user_id'])? $storeInfo['user_id'] : 0;
        if($storeUserId<=0){
            $this->error = '企业账号错误';
            return false;
        }

        if(!StoreModel::where(['id'=> $storeId])->update(['bonus_total'=>DB::raw("bonus_total + {$money}"),'update_time'=>time()])){
            $this->error = '收货错误，企业结算错误，请联系客服处理';
            return -1;
        }

        $log = [
            'user_id'=> $storeUserId,
            'store_id'=> $storeId,
            'source_order_no'=> isset($order['order_no'])? $order['order_no'] : '',
            'type'=> 7,
            'money'=> $money,
            'after_money'=> moneyFormat($balance+$money,2),
            'date'=>date('Y-m-d'),
            'create_time'=>time(),
            'remark'=> '收益',
            'status'=>1
        ];
        if(!$id = $this->model->insertGetId($log)){
            $this->error = '企业收益结算失败，请联系客服处理';
            return -1;
        }

        $result = ['id'=>$id,'store_id'=>$storeId,'bonus'=>$money];
        if(env('APP_DEBUG')){
            RedisService::set("caches:settle:{$orderNo}:store_{$storeId}", $result, 7200);
        }

        return $result;
    }

    public function businessBonus($userId, $total, $commission, $order)
    {

    }

    public function shopBonus($userId, $total, $commission, $order)
    {

    }

    /**
     * @param $order
     * @param int $orderType
     */
    public function commissionCount($order, $orderGoods, $userInfo, $orderType=1)
    {
        $userId = isset($order['user_id'])?$order['user_id']:0;
        $storeId = isset($order['store_id'])?$order['store_id']:0;
        $mealId = isset($order['meal_id'])?$order['meal_id']:0;
        $orderNo = isset($order['order_no'])?$order['order_no']:'';
        $orderTotal = isset($order['pay_total'])?$order['pay_total']:0;
        $profitTotal = isset($order['profit_total'])?$order['profit_total']:0;
        $data = [
            'user_id'=> $userId,
            'order_no'=> $orderNo,
            'store_id'=> $storeId,
            'create_time'=>time(),
            'status'=>2,
            'mark'=>1,
        ];
        $errors = [];
        if($orderType==2){
            /*  TODO 计算直推奖  */
            $pointId = isset($userInfo['point_id'])? $userInfo['point_id']:0;
            $directBonus = ConfigService::make()->getConfigByCode('business_direct_bonus', 0);
            $directBonus = $directBonus>0 && $directBonus<$orderTotal?$directBonus:0;
            $pointInfo = MemberModel::where(['id' => $pointId,'mark'=>1])
                ->select(['id','nickname','buy_type','bonus_status','status','mark'])
                ->first();
            $buyType = isset($pointInfo['buy_type'])?$pointInfo['buy_type']:0;
            $bonusStatus = isset($pointInfo['bonus_status'])?$pointInfo['bonus_status']:0;
            $data['direct_uid'] = $pointId;
            if($pointInfo && $buyType==$mealId && $bonusStatus==1){
                $data['direct_bonus'] = $directBonus;
            }else{
                $errors['direct_bonus']=['uid'=>$pointId,'bonus'=>$directBonus,'error'=>'节点推荐人不存在或收益已领完','point'=>$pointInfo];
            }

            /* TODO 计算见单奖和分红奖励  */
            $points = isset($userInfo['points'])?$userInfo['points']:'';
            $points = $points? explode(',',$points) : [];
            $points = array_filter($points);
            $points = array_reverse($points); // 由下到上1-6层
            $rewardLayer = ConfigService::make()->getConfigByCode('business_reward_layer', 6);
            $points = array_splice($points,0, $rewardLayer);
            $jdBonus = ConfigService::make()->getConfigByCode("business_jd_bonus_{$mealId}", 0);
            $jdBonus = $jdBonus>0 && $jdBonus< $orderTotal? $jdBonus : 0;

            // 计算当前平台下各个等级的会员数量
            $levelCounts = MemberService::make()->getCountsByLevel();
            $levelList = MemberLevelService::make()->getListByLevel();

            if($points){
                $pointList = MemberModel::with(['levelData'])->whereIn('id', $points)
                    ->select(['id','nickname','mobile','buy_type','member_level','bonus_status','status','mark'])
                    ->orderBy(DB::raw("FIELD(id, ".implode(',',$points).")"))
                    ->get();
                foreach ($pointList as $k => $point){
                    // 默认只分6层
                    $layer = $k+1;
                    if($layer>$rewardLayer){
                        continue;
                    }


                    // 处理见单奖
                    $pid = isset($point['id'])?$point['id']:0;
                    $pMark = isset($point['mark'])?$point['mark']:0;
                    $buyType = isset($point['buy_type'])?$point['buy_type']:0;
                    $bonusStatus = isset($point['bonus_status'])?$point['bonus_status']:0;
                    $pLevel = isset($point['member_level'])?$point['member_level']:0;
                    $levelWeightCountData = isset($levelCounts[$pLevel])? $levelCounts[$pLevel] : 0;
                    $levelData = isset($levelList[$pLevel])? $levelList[$pLevel] : 0;
                    $levelWeightCount = isset($levelWeightCountData['count'])? $levelWeightCountData['count']:0;
                    $levelBonus = isset($levelData['bonus'])? $levelData['bonus']:0;
                    $data["bonus_{$layer}_uid"] = $pid;

                    $bonusData = [
                        'id'=> $pid,
                        'nickname'=> isset($point['nickname'])?$point['nickname']:'',
                        'mobile'=> isset($point['mobile'])?$point['mobile']:'',
                        'jd_bonus'=> 0,
                        'level'=> $pLevel,
                        'weight'=> $levelWeightCount,
                        'weight_bonus'=> $levelBonus,
                        'level_bonus'=> 0,
                    ];
                    if($pMark==1 && $buyType==$mealId && $bonusStatus==1){
                        $bonusData['jd_bonus'] = $jdBonus;
                    }else{
                        $errors["bonus_{$layer}_uid_jd"]=['uid'=>$pid,'bonus'=>$jdBonus,'error'=>"上{$layer}级节点推荐人不存在或收益已领完",'point'=>$point];
                    }

                    // 处理加权分红
                    if($pLevel>0 && $levelWeightCount>0 && $levelBonus>0){
                        $bonusData['level_bonus'] = moneyFormat($levelBonus * 6/$levelWeightCount,2);
                    }

                    // 数据
                    $data["bonus_{$layer}_data"] = json_encode($bonusData,256);
                }
            }

        }else{
            /* TODO 计算商家佣金 */
            $storeInfo = StoreModel::where(['id' => $storeId])->first();
            $bonusRate = isset($storeInfo['bonus_rate']) ? floatval($storeInfo['bonus_rate']) : 0;
            $storeBonusRate = ConfigService::make()->getConfigByCode('store_bonus_rate', 0);
            $storeBonusRate = $storeBonusRate > 0 && $storeBonusRate <= 100 ? $storeBonusRate : 0;
            $bonusRate = $bonusRate > 0 && $bonusRate <= 100 ? $bonusRate : $storeBonusRate;
            $bonus = moneyFormat($orderTotal * $bonusRate / 100, 2);
            $data['bonus'] = $bonus;
            $data['bonus_rate'] = $bonusRate;


            /* TODO 计算绿色积分奖励 */
            $lsScoreTotal = 0;
            $data['ls_score_rates'] = [];
            $ptLsScoreRate = ConfigService::make()->getConfigByCode('ls_score_rate',0);
            $ptLsScoreRate = $ptLsScoreRate>0&&$ptLsScoreRate<=50?$ptLsScoreRate:0;
            if($orderGoods){
                foreach ($orderGoods as $goods){
                    $lsScoreRate = isset($goods['ls_score_rate'])?$goods['ls_score_rate']:0;
                    $lsScoreRate = $lsScoreRate>0 && $lsScoreRate<=50?$lsScoreRate : $ptLsScoreRate;
                    $profitTotal = isset($goods['profit_total'])?$goods['profit_total'] : 0;
                    if($profitTotal>0 && $lsScoreRate>0){
                        $lsScoreTotal += moneyFormat($profitTotal * $lsScoreRate/100,2);
                    }
                    $data['ls_score_rates'][$goods['goods_id']] = $lsScoreRate;
                }
            }
            $data['ls_score'] = $lsScoreTotal;
            $data['ls_score_rates'] = json_encode($data['ls_score_rates'], 256);


            /* TODO 计算数字资产+底池金额 */
            $ptPoolRate = ConfigService::make()->getConfigByCode('pt_pool_rate', 0);
            $ptPoolRate = $ptPoolRate>0 && $ptPoolRate<50?$ptPoolRate:0;
            $rewardPropertyRate = ConfigService::make()->getConfigByCode('reward_property_rate', 0);
            $rewardPropertyRate = $rewardPropertyRate > 0 && $rewardPropertyRate <= 50 ? $rewardPropertyRate : 0;
            $propertyTotal = moneyFormat($rewardPropertyRate * $profitTotal/100,2);
            $poolTotal = moneyFormat($ptPoolRate * $profitTotal/100,2);
            $data['pt_pool_rate'] = $ptPoolRate;
            $data['pt_pool'] = $poolTotal;
            $data['property'] = $propertyTotal;
            $data['property_rate'] = $rewardPropertyRate;
        }

        // 佣金数据入库
        if(!$cid = OrderCommissionModel::where(['order_no'=>$orderNo])->value('id')){
            $cid = OrderCommissionModel::insertGetId($data);
        }else{
            OrderCommissionModel::where(['id'=>$cid])->update($data);
        }

        $this->error = '佣金计算成功';
        $data['id'] = $cid;
        return $data;
    }

    /**
     * 新人注册奖励
     * @param $userId
     * @return array|bool
     */
    public function registerReward($userId)
    {
        $rewardOpen = ConfigService::make()->getConfigByCode('register_award_coupon',0);
        $rewardCouponId = ConfigService::make()->getConfigByCode('register_reward_coupon_id',0);
        if($rewardCouponId<=0 || $rewardOpen!= 1){
            $this->error = '未开启或配置注册优惠券奖励';
            return true;
        }

        $couponInfo = CouponModel::where(['id'=>$rewardCouponId,'mark'=>1])
            ->first();
        $status = isset($couponInfo['status'])?$couponInfo['status']:0;
        if(empty($couponInfo) || $status != 1){
            $this->error = '配置的注册奖励优惠券不存在或无效';
            return true;
        }

        $data = [
            'coupon_id'=> $rewardCouponId,
            'user_id'=> $userId,
            'store_id'=> isset($couponInfo['store_id'])?$couponInfo['store_id']:0,
            'name'=> isset($couponInfo['name'])?$couponInfo['name']:'',
            'coupon_type'=> isset($couponInfo['coupon_type'])?$couponInfo['coupon_type']: 20,
            'reduce_price'=> isset($couponInfo['reduce_price'])?$couponInfo['reduce_price']:0,
            'discount'=> isset($couponInfo['discount'])?$couponInfo['discount']:0,
            'min_price'=> isset($couponInfo['min_price'])?$couponInfo['min_price']:0,
            'expire_day'=> isset($couponInfo['expire_day'])?$couponInfo['expire_day']:0,
            'start_time'=> isset($couponInfo['start_time'])?$couponInfo['start_time']:0,
            'end_time'=> isset($couponInfo['end_time'])?$couponInfo['end_time']:0,
            'goods_ids'=> isset($couponInfo['goods_ids'])&&$couponInfo['goods_ids']?$couponInfo['goods_ids']:'',
            'create_time'=> time(),
            'status'=> 1,
        ];

        if(!$id = MemberCouponModel::insertGetId($data)){
            $this->error = '奖励注册优惠券失败';
            return true;
        }

        $data['id'] = $id;
        $data['discount'] = floatval($data['discount']);
        $data['reduce_price'] = floatval($data['reduce_price']);
        unset($data['create_time']);
        unset($data['status']);
        unset($data['goods_ids']);
        $this->error = '奖励注册优惠券成功';
        return $data;
    }
}