yanzong/app/timer/service/dealer/Order.php

<?php
// +----------------------------------------------------------------------
// | 萤火商城系统 [ 致力于通过产品和服务，帮助商家高效化开拓市场 ]
// +----------------------------------------------------------------------
// | Copyright (c) 2017~2023 https://www.yiovo.com All rights reserved.
// +----------------------------------------------------------------------
// | Licensed 这不是一个自由软件，不允许对程序代码以任何形式任何目的的再发行
// +----------------------------------------------------------------------
// | Author: 萤火科技 <admin@yiovo.com>
// +----------------------------------------------------------------------
declare (strict_types=1);

namespace app\timer\service\dealer;

use app\common\library\helper;
use app\common\service\BaseService;
use app\timer\library\Tools;
use app\timer\model\dealer\Order as DealerOrderModel;
use app\timer\model\dealer\User as DealerUserModel;
use think\model\Collection;

/**
 * 服务类：分销订单模块
 * Class Order
 * @package app\timer\service\dealer
 */
class Order extends BaseService
{
    /**
     * 标记失效的分销订单
     * @param int $storeId
     * @return bool
     */
    public function invalidEvent(int $storeId): bool
    {
        // 获取已失效的订单ID集
        $model = new DealerOrderModel;
        $invalidOrderIds = $model->getInvalidOrderIds($storeId);
        // 记录日志
        Tools::taskLogs('DealerOrder', 'invalidEvent', [
            'storeId' => $storeId,
            'invalidOrderIds' => helper::jsonEncode($invalidOrderIds)
        ]);
        // 标记订单失效状态
        return empty($invalidOrderIds) || $model->setInvalid($invalidOrderIds);
    }

    /**
     * 分销佣金结算（已完成订单）
     * @param int $storeId
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function grantMoneyEvent(int $storeId)
    {
        // 获取未结算的分销订单
        $model = new DealerOrderModel;
        $orderList = $model->getUnSettledList($storeId);
        // 发放分销订单佣金
        $this->settlement($storeId, $orderList);
        // 记录日志
        Tools::taskLogs('DealerOrder', 'grantMoneyEvent', [
            'storeId' => $storeId,
            'ids' => helper::jsonEncode(helper::getArrayColumn($orderList, 'id')),
            'orderIds' => helper::jsonEncode(helper::getArrayColumn($orderList, 'order_id'))
        ]);
    }

    /**
     * 发放分销订单佣金(批量)
     * @param int $storeId
     * @param Collection $orderList
     */
    public function settlement(int $storeId, Collection $orderList)
    {
        $model = new DealerOrderModel;
        $model->transaction(function () use ($storeId, $orderList) {
            foreach ($orderList as $order) {
                static::grantMoneyOrder($storeId, $order);
            }
        });
    }

    /**
     * 发放分销订单佣金(单独)
     * @param int $storeId
     * @param DealerOrderModel $orderItem 分销订单详情
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    private static function grantMoneyOrder(int $storeId, DealerOrderModel $orderItem): void
    {
        // 判断存在未处理的售后退款, 则不进行分佣
        if (static::checkExistRefunding($orderItem)) {
            return;
        }
        // 重新计算分销佣金
        $capital = DealerOrderModel::getCapitalByOrder($orderItem['order']);
        // 发放一级分销商佣金
        $orderItem['first_user_id'] > 0 && DealerUserModel::grantMoney((int)$orderItem['first_user_id'], (float)$capital['first_money'], $storeId);
        // 发放二级分销商佣金
        $orderItem['second_user_id'] > 0 && DealerUserModel::grantMoney((int)$orderItem['second_user_id'], (float)$capital['second_money'], $storeId);
        // 发放三级分销商佣金
        $orderItem['third_user_id'] > 0 && DealerUserModel::grantMoney((int)$orderItem['third_user_id'], (float)$capital['third_money'], $storeId);
        // 更新分销订单记录
        $orderItem->save([
            'order_price' => $capital['orderPrice'],
            'first_money' => $capital['first_money'],
            'second_money' => $capital['second_money'],
            'third_money' => $capital['third_money'],
            'is_settled' => 1,
            'settle_time' => time()
        ]);
    }

    /**
     * 验证商品是否存在售后退款(进行中)
     * @param DealerOrderModel $orderItem
     * @return bool
     */
    private static function checkExistRefunding(DealerOrderModel $orderItem): bool
    {
        foreach ($orderItem['order']['goods'] as $item) {
            if (DealerOrderModel::checkExistRefunding($item)) {
                return true;
            }
        }
        return false;
    }
}