feat: add syj promote workflow

pro_v3.5.1/app/services/syj/SyjPromoteConfigServices.php

@@ -0,0 +1,100 @@
+<?php
+declare(strict_types=1);
+
+namespace app\services\syj;
+
+use app\services\BaseServices;
+use app\services\system\config\SystemConfigServices;
+use crmeb\services\SystemConfigService;
+use think\exception\ValidateException;
+
+class SyjPromoteConfigServices extends BaseServices
+{
+    public function getConfig(): array
+    {
+        return [
+            'base_amount' => $this->money('syj_task_base_amount', '4333'),
+            'target_count' => (int)SystemConfigService::get('syj_task_target_count', 4),
+            'reward_rates' => $this->rewardRates(),
+            'early_cashout_fee_rate' => $this->money('syj_early_cashout_fee_rate', '7'),
+            'task_generate_timing' => (string)SystemConfigService::get('syj_task_generate_timing', 'on_confirm'),
+            'task_order_dedupe' => (string)SystemConfigService::get('syj_task_order_dedupe', 'order'),
+            'reward_trigger_enable' => (int)SystemConfigService::get('syj_reward_trigger_enable', 1),
+            'brokerage_timing' => (string)SystemConfigService::get('brokerage_timing', 'on_confirm'),
+        ];
+    }
+
+    public function saveConfig(array $data): void
+    {
+        $baseAmount = (float)($data['base_amount'] ?? 0);
+        $targetCount = (int)($data['target_count'] ?? 0);
+        $rates = $data['reward_rates'] ?? [];
+        if (is_string($rates)) {
+            $rates = json_decode($rates, true) ?: [];
+        }
+        $feeRate = (float)($data['early_cashout_fee_rate'] ?? -1);
+        $generateTiming = (string)($data['task_generate_timing'] ?? 'on_confirm');
+
+        if ($baseAmount <= 0) {
+            throw new ValidateException('任务基准金额必须大于0');
+        }
+        if ($targetCount <= 0) {
+            throw new ValidateException('目标单数必须大于0');
+        }
+        if (count($rates) !== $targetCount) {
+            throw new ValidateException('奖励比例数量必须与目标单数一致');
+        }
+        foreach ($rates as $rate) {
+            if ((float)$rate < 0 || (float)$rate > 100) {
+                throw new ValidateException('奖励比例必须在0到100之间');
+            }
+        }
+        if ($feeRate < 0 || $feeRate > 100) {
+            throw new ValidateException('扣费比例必须在0到100之间');
+        }
+        if (!in_array($generateTiming, ['on_confirm', 'on_pay'], true)) {
+            throw new ValidateException('任务生成节点不正确');
+        }
+
+        /** @var SystemConfigServices $configServices */
+        $configServices = app()->make(SystemConfigServices::class);
+        $map = [
+            'syj_task_base_amount' => $this->formatMoney($baseAmount),
+            'syj_task_target_count' => (string)$targetCount,
+            'syj_task_reward_rates' => json_encode(array_values(array_map('floatval', $rates)), JSON_UNESCAPED_UNICODE),
+            'syj_early_cashout_fee_rate' => $this->formatMoney($feeRate),
+            'syj_task_generate_timing' => $generateTiming,
+            'syj_task_order_dedupe' => (string)($data['task_order_dedupe'] ?? 'order'),
+            'syj_reward_trigger_enable' => (string)(int)($data['reward_trigger_enable'] ?? 1),
+        ];
+        foreach ($map as $key => $value) {
+            $configServices->setConfig($key, $value);
+        }
+    }
+
+    public function rewardRates(): array
+    {
+        $value = SystemConfigService::get('syj_task_reward_rates', '[10,20,30,40]');
+        if (is_array($value)) {
+            return array_values(array_map('floatval', $value));
+        }
+        $decoded = json_decode((string)$value, true);
+        return is_array($decoded) ? array_values(array_map('floatval', $decoded)) : [10, 20, 30, 40];
+    }
+
+    public function rateForStep(int $step): float
+    {
+        $rates = $this->rewardRates();
+        return (float)($rates[$step - 1] ?? 0);
+    }
+
+    private function money(string $key, string $default): string
+    {
+        return $this->formatMoney((float)SystemConfigService::get($key, $default));
+    }
+
+    public function formatMoney(float|string $number): string
+    {
+        return number_format((float)$number, 2, '.', '');
+    }
+}

pro_v3.5.1/app/services/syj/SyjPromoteRewardTriggerServices.php

@@ -0,0 +1,104 @@
+<?php
+declare(strict_types=1);
+
+namespace app\services\syj;
+
+use app\dao\syj\PromoteRewardTriggerDao;
+use app\services\BaseServices;
+use app\services\agent\AgentLevelServices;
+use app\services\hjf\PointsRewardServices;
+use app\services\user\UserServices;
+use think\annotation\Inject;
+use think\facade\Log;
+
+class SyjPromoteRewardTriggerServices extends BaseServices
+{
+    #[Inject]
+    protected PromoteRewardTriggerDao $dao;
+
+    public function triggerForTask(array $task): void
+    {
+        if ((int)sys_config('syj_reward_trigger_enable', 1) !== 1) {
+            return;
+        }
+        $taskId = (int)$task['id'];
+        $triggerNo = $task['reward_trigger_no'] ?: 'SYJ-TASK-' . $taskId;
+        if (!$this->dao->be(['task_id' => $taskId])) {
+            $this->dao->save([
+                'task_id' => $taskId,
+                'uid' => (int)$task['uid'],
+                'trigger_no' => $triggerNo,
+                'trigger_amount' => $task['base_amount'],
+                'brokerage_status' => 0,
+                'points_status' => 0,
+                'level_task_status' => 0,
+                'error_msg' => '',
+            ]);
+        }
+
+        $status = [
+            'points_status' => 1,
+            'level_task_status' => 1,
+            'brokerage_status' => 1,
+            'error_msg' => '',
+        ];
+
+        try {
+            /** @var UserServices $userServices */
+            $userServices = app()->make(UserServices::class);
+            $uids = [(int)$task['uid']];
+            $user = $userServices->get((int)$task['uid'], ['uid', 'spread_uid', 'agent_level']);
+            $spreadUid = $user ? (int)($user['spread_uid'] ?? 0) : 0;
+            if ($spreadUid > 0) {
+                $uids[] = $spreadUid;
+                $spreadUser = $userServices->get($spreadUid, ['uid', 'spread_uid', 'agent_level']);
+                $twoUid = $spreadUser ? (int)($spreadUser['spread_uid'] ?? 0) : 0;
+                if ($twoUid > 0) {
+                    $uids[] = $twoUid;
+                }
+            }
+            $preUpgradeLevels = [];
+            foreach (array_unique($uids) as $uid) {
+                if ($uid <= 0) continue;
+                $row = $userServices->get((int)$uid, ['uid', 'agent_level']);
+                $preUpgradeLevels[(int)$uid] = $row ? (int)($row['agent_level'] ?? 0) : 0;
+            }
+
+            /** @var AgentLevelServices $agentLevelServices */
+            $agentLevelServices = app()->make(AgentLevelServices::class);
+            $agentLevelServices->checkUserLevelFinish((int)$task['uid'], array_keys($preUpgradeLevels));
+        } catch (\Throwable $e) {
+            $status['level_task_status'] = 2;
+            $status['error_msg'] = '等级任务触发失败：' . $e->getMessage();
+            Log::error('[SYJ] 等级任务触发失败 task=' . $taskId . ' ' . $e->getMessage());
+        }
+
+        try {
+            /** @var PointsRewardServices $pointsRewardServices */
+            $pointsRewardServices = app()->make(PointsRewardServices::class);
+            $pointsRewardServices->reward((int)$task['uid'], $triggerNo, (int)$task['source_order_id'], $preUpgradeLevels ?? [], 1);
+        } catch (\Throwable $e) {
+            $status['points_status'] = 2;
+            $status['error_msg'] = trim($status['error_msg'] . ' 积分触发失败：' . $e->getMessage());
+            Log::error('[SYJ] 积分触发失败 task=' . $taskId . ' ' . $e->getMessage());
+        }
+
+        $this->dao->update(['task_id' => $taskId], $status + ['retry_count' => $this->dao->value(['task_id' => $taskId], 'retry_count')]);
+    }
+
+    public function retry(int $taskId): void
+    {
+        /** @var SyjPromoteTaskServices $taskServices */
+        $taskServices = app()->make(SyjPromoteTaskServices::class);
+        $task = $taskServices->getTask($taskId);
+        if (!$task) {
+            return;
+        }
+        $row = $this->dao->getOne(['task_id' => $taskId]);
+        if ($row) {
+            $this->dao->update(['task_id' => $taskId], ['retry_count' => (int)$row['retry_count'] + 1]);
+        }
+        $this->triggerForTask($task);
+        $taskServices->refreshRewardStatus($taskId);
+    }
+}

pro_v3.5.1/app/services/syj/SyjPromoteSettlementServices.php

@@ -0,0 +1,168 @@
+<?php
+declare(strict_types=1);
+
+namespace app\services\syj;
+
+use app\dao\syj\PromoteSettlementDao;
+use app\dao\syj\PromoteTaskDao;
+use app\services\BaseServices;
+use app\services\user\UserBrokerageServices;
+use app\services\user\UserServices;
+use think\annotation\Inject;
+use think\exception\ValidateException;
+use think\facade\Db;
+
+class SyjPromoteSettlementServices extends BaseServices
+{
+    #[Inject]
+    protected PromoteSettlementDao $dao;
+
+    #[Inject]
+    protected PromoteTaskDao $taskDao;
+
+    public function complete(array $task): array
+    {
+        return Db::transaction(function () use ($task) {
+            $taskId = (int)$task['id'];
+            if ($this->dao->be(['task_id' => $taskId, 'settle_type' => 'complete'])) {
+                return $this->dao->getOne(['task_id' => $taskId, 'settle_type' => 'complete'])->toArray();
+            }
+            $gross = $this->money($task['base_amount']);
+            $settlement = $this->dao->save([
+                'task_id' => $taskId,
+                'uid' => (int)$task['uid'],
+                'settle_type' => 'complete',
+                'gross_amount' => $gross,
+                'fee_rate' => '0.00',
+                'fee_amount' => '0.00',
+                'net_amount' => $gross,
+                'audit_status' => 1,
+                'audit_time' => time(),
+            ])->toArray();
+            $brokerageId = $this->grantBrokerage((int)$task['uid'], $gross, $taskId, '推四免一任务完成结算，任务号：' . $task['task_no']);
+            $this->dao->update((int)$settlement['id'], ['brokerage_id' => $brokerageId]);
+            $this->taskDao->update($taskId, ['status' => 1, 'finish_time' => time()]);
+            return $settlement;
+        });
+    }
+
+    public function applyCashout(int $uid, int $taskId): array
+    {
+        return Db::transaction(function () use ($uid, $taskId) {
+            $task = $this->taskDao->get($taskId);
+            if (!$task || (int)$task['uid'] !== $uid) {
+                throw new ValidateException('推广任务不存在');
+            }
+            if ((int)$task['status'] !== 0) {
+                throw new ValidateException('当前任务状态不可提前兑现');
+            }
+            $progress = (int)$task['progress_count'];
+            if ($progress < 1 || $progress >= (int)$task['target_count']) {
+                throw new ValidateException('当前进度不可提前兑现');
+            }
+            if ($this->dao->be(['task_id' => $taskId, 'settle_type' => 'early_cashout'])) {
+                throw new ValidateException('已提交提前兑现申请');
+            }
+            [$gross, $fee, $net] = $this->calcEarlyCashout($task->toArray());
+            $settlement = $this->dao->save([
+                'task_id' => $taskId,
+                'uid' => $uid,
+                'settle_type' => 'early_cashout',
+                'gross_amount' => $gross,
+                'fee_rate' => $this->money($task['fee_rate']),
+                'fee_amount' => $fee,
+                'net_amount' => $net,
+                'audit_status' => 0,
+            ])->toArray();
+            $this->taskDao->update($taskId, ['status' => 5]);
+            return $settlement;
+        });
+    }
+
+    public function auditCashout(int $settlementId, int $auditUid, int $status, string $remark = ''): void
+    {
+        Db::transaction(function () use ($settlementId, $auditUid, $status, $remark) {
+            $settlement = $this->dao->get($settlementId);
+            if (!$settlement || $settlement['settle_type'] !== 'early_cashout') {
+                throw new ValidateException('提前兑现申请不存在');
+            }
+            if ((int)$settlement['audit_status'] !== 0) {
+                throw new ValidateException('申请已审核');
+            }
+            $task = $this->taskDao->get((int)$settlement['task_id']);
+            if (!$task || (int)$task['status'] !== 5) {
+                throw new ValidateException('任务状态不可审核');
+            }
+            if ($status === 1) {
+                $brokerageId = $this->grantBrokerage((int)$settlement['uid'], (string)$settlement['net_amount'], (int)$task['id'], '推四免一提前兑现到账，任务号：' . $task['task_no']);
+                $this->dao->update($settlementId, [
+                    'audit_status' => 1,
+                    'audit_uid' => $auditUid,
+                    'audit_remark' => $remark,
+                    'audit_time' => time(),
+                    'brokerage_id' => $brokerageId,
+                ]);
+                $this->taskDao->update((int)$task['id'], ['status' => 2, 'cashout_time' => time()]);
+            } elseif ($status === 2) {
+                $this->dao->update($settlementId, [
+                    'audit_status' => 2,
+                    'audit_uid' => $auditUid,
+                    'audit_remark' => $remark,
+                    'audit_time' => time(),
+                ]);
+                $this->taskDao->update((int)$task['id'], ['status' => 0]);
+            } else {
+                throw new ValidateException('审核状态不正确');
+            }
+        });
+    }
+
+    public function listForUser(int $uid, int $page, int $limit): array
+    {
+        return $this->dao->getUserList($uid, $page, $limit);
+    }
+
+    public function adminList(array $where, int $page, int $limit): array
+    {
+        return $this->dao->getAdminList($where, $page, $limit);
+    }
+
+    private function calcEarlyCashout(array $task): array
+    {
+        $rates = json_decode((string)$task['reward_rates'], true);
+        if (!is_array($rates)) {
+            $rates = [10, 20, 30, 40];
+        }
+        $step = max(1, (int)$task['progress_count']);
+        $rate = (float)($rates[$step - 1] ?? 0);
+        $gross = bcmul((string)$task['base_amount'], bcdiv((string)$rate, '100', 4), 2);
+        $fee = bcmul($gross, bcdiv((string)$task['fee_rate'], '100', 4), 2);
+        $net = bcsub($gross, $fee, 2);
+        return [$gross, $fee, $net];
+    }
+
+    private function grantBrokerage(int $uid, string $amount, int $taskId, string $mark): int
+    {
+        /** @var UserServices $userServices */
+        $userServices = app()->make(UserServices::class);
+        $current = (string)($userServices->value(['uid' => $uid], 'brokerage_price') ?: '0');
+        $balance = bcadd($current, $amount, 2);
+        $userServices->bcInc($uid, 'brokerage_price', $amount, 'uid');
+
+        /** @var UserBrokerageServices $brokerageServices */
+        $brokerageServices = app()->make(UserBrokerageServices::class);
+        $row = $brokerageServices->income('syj_promote_settlement', $uid, [
+            'number' => $amount,
+            'mark' => $mark,
+        ], $balance, $taskId);
+        if ($row && method_exists($row, 'getData')) {
+            return (int)$row->getData('id');
+        }
+        return 0;
+    }
+
+    private function money(float|string $amount): string
+    {
+        return number_format((float)$amount, 2, '.', '');
+    }
+}

pro_v3.5.1/app/services/syj/SyjPromoteTaskServices.php

@@ -0,0 +1,309 @@
+<?php
+declare(strict_types=1);
+
+namespace app\services\syj;
+
+use app\dao\syj\PromoteAmountLogDao;
+use app\dao\syj\PromoteRewardTriggerDao;
+use app\dao\syj\PromoteSettlementDao;
+use app\dao\syj\PromoteTaskDao;
+use app\dao\syj\PromoteTaskRecordDao;
+use app\dao\syj\PromoteUserAmountDao;
+use app\services\BaseServices;
+use think\annotation\Inject;
+use think\exception\ValidateException;
+use think\facade\Db;
+use think\facade\Log;
+
+class SyjPromoteTaskServices extends BaseServices
+{
+    #[Inject]
+    protected PromoteTaskDao $taskDao;
+
+    #[Inject]
+    protected PromoteUserAmountDao $userAmountDao;
+
+    #[Inject]
+    protected PromoteAmountLogDao $amountLogDao;
+
+    #[Inject]
+    protected PromoteTaskRecordDao $recordDao;
+
+    #[Inject]
+    protected PromoteSettlementDao $settlementDao;
+
+    #[Inject]
+    protected PromoteRewardTriggerDao $triggerDao;
+
+    public function handleOrderEffective(array $order, string $sourceType = 'order_confirm'): void
+    {
+        if (!$this->isQueueOrder($order) || empty($order['uid'])) {
+            return;
+        }
+        $generateTiming = (string)sys_config('syj_task_generate_timing', 'on_confirm');
+        if (($generateTiming === 'on_confirm' && $sourceType !== 'order_confirm') || ($generateTiming === 'on_pay' && $sourceType !== 'order_pay')) {
+            return;
+        }
+
+        Db::transaction(function () use ($order) {
+            $orderId = (int)$order['id'];
+            if ($this->amountLogDao->be(['order_id' => $orderId, 'type' => 'income'])) {
+                return;
+            }
+            $uid = (int)$order['uid'];
+            $amount = $this->validAmount($order);
+            if (bccomp($amount, '0', 2) <= 0) {
+                return;
+            }
+            $summary = $this->lockUserAmount($uid);
+            $before = (string)$summary['pending_amount'];
+            $afterIncome = bcadd($before, $amount, 2);
+            $config = app()->make(SyjPromoteConfigServices::class)->getConfig();
+            $base = $config['base_amount'];
+            $taskCount = (int)floor((float)bcdiv($afterIncome, $base, 4));
+            $remaining = bcsub($afterIncome, bcmul((string)$taskCount, $base, 2), 2);
+
+            $this->amountLogDao->save([
+                'uid' => $uid,
+                'order_id' => $orderId,
+                'order_no' => (string)$order['order_id'],
+                'amount' => $amount,
+                'before_amount' => $before,
+                'after_amount' => $afterIncome,
+                'type' => 'income',
+                'mark' => '有效消费计入待推广金额',
+            ]);
+
+            $this->userAmountDao->update((int)$summary['id'], ['pending_amount' => $remaining]);
+
+            for ($i = 1; $i <= $taskCount; $i++) {
+                $task = $this->createTask($uid, $order, $i, $config);
+                $this->amountLogDao->save([
+                    'uid' => $uid,
+                    'order_id' => $orderId,
+                    'order_no' => (string)$order['order_id'],
+                    'amount' => '-' . $base,
+                    'before_amount' => $afterIncome,
+                    'after_amount' => $remaining,
+                    'type' => 'consume_task_' . $i,
+                    'link_id' => (int)$task['id'],
+                    'mark' => '生成推四免一推广任务',
+                ]);
+            }
+        });
+    }
+
+    public function handleRecommendedOrder(array $order, string $sourceType): void
+    {
+        if (!$this->isQueueOrder($order) || empty($order['spread_uid'])) {
+            return;
+        }
+        $timing = (string)sys_config('brokerage_timing', 'on_confirm');
+        if (($timing === 'on_pay' && $sourceType !== 'order_pay') || ($timing === 'on_confirm' && $sourceType !== 'order_confirm')) {
+            return;
+        }
+        Db::transaction(function () use ($order, $sourceType, $timing) {
+            $orderId = (int)$order['id'];
+            if ($this->recordDao->be(['order_id' => $orderId])) {
+                return;
+            }
+            $task = $this->taskDao->getEarliestActiveTask((int)$order['spread_uid']);
+            if (!$task) {
+                return;
+            }
+            $step = (int)$task['progress_count'] + 1;
+            $rates = json_decode((string)$task['reward_rates'], true);
+            $rate = (float)($rates[$step - 1] ?? 0);
+            $this->recordDao->save([
+                'task_id' => (int)$task['id'],
+                'uid' => (int)$task['uid'],
+                'order_uid' => (int)$order['uid'],
+                'order_id' => $orderId,
+                'order_no' => (string)$order['order_id'],
+                'source_type' => $sourceType,
+                'trigger_timing' => $timing,
+                'step_no' => $step,
+                'reward_rate' => $rate,
+                'status' => 1,
+            ]);
+            $this->taskDao->update((int)$task['id'], ['progress_count' => $step]);
+            $task['progress_count'] = $step;
+            if ($step >= (int)$task['target_count']) {
+                app()->make(SyjPromoteSettlementServices::class)->complete($task);
+            }
+        });
+    }
+
+    public function handleRefund(array $order, array $refundData = []): void
+    {
+        Db::transaction(function () use ($order, $refundData) {
+            $orderId = (int)$order['id'];
+            $sourceTasks = $this->taskDao->getColumn(['source_order_id' => $orderId], 'id,status', 'id');
+            if ($sourceTasks) {
+                foreach ($sourceTasks as $taskId => $status) {
+                    if ((int)$status === 0) {
+                        $this->taskDao->update((int)$taskId, ['status' => 4, 'exception_reason' => '来源订单退款']);
+                    }
+                }
+            }
+            $record = $this->recordDao->getOne(['order_id' => $orderId, 'status' => 1]);
+            if ($record) {
+                $task = $this->taskDao->get((int)$record['task_id']);
+                $this->recordDao->update((int)$record['id'], ['status' => 2]);
+                if ($task && (int)$task['status'] === 0) {
+                    $this->taskDao->update((int)$task['id'], ['progress_count' => max(0, (int)$task['progress_count'] - 1)]);
+                } elseif ($task) {
+                    $this->taskDao->update((int)$task['id'], ['status' => 4, 'exception_reason' => '推荐订单退款，需人工复核']);
+                }
+            }
+        });
+    }
+
+    public function overview(int $uid): array
+    {
+        $summary = $this->userAmountDao->getOne(['uid' => $uid]);
+        $pending = $summary ? (string)$summary['pending_amount'] : '0.00';
+        $base = (string)sys_config('syj_task_base_amount', '4333');
+        return [
+            'pending_amount' => $this->money($pending),
+            'base_amount' => $this->money($base),
+            'active_task_count' => $this->taskDao->count(['uid' => $uid, 'status' => 0]),
+            'completed_task_count' => $this->taskDao->count(['uid' => $uid, 'status' => 1]),
+            'cashout_task_count' => $this->taskDao->count(['uid' => $uid, 'status' => 2]),
+            'available_cashout_amount' => $this->availableCashoutAmount($uid),
+        ];
+    }
+
+    public function userTasks(int $uid, array $where, int $page, int $limit): array
+    {
+        return $this->taskDao->getUserList($uid, $where, $page, $limit);
+    }
+
+    public function adminTasks(array $where, int $page, int $limit): array
+    {
+        return $this->taskDao->getAdminList($where, $page, $limit);
+    }
+
+    public function getTask(int $taskId): ?array
+    {
+        $row = $this->taskDao->get($taskId);
+        return $row ? $row->toArray() : null;
+    }
+
+    public function userTaskDetail(int $uid, int $taskId): array
+    {
+        $task = $this->getTask($taskId);
+        if (!$task || (int)$task['uid'] !== $uid) {
+            throw new ValidateException('推广任务不存在');
+        }
+        return $this->decorateTask($task);
+    }
+
+    public function adminTaskDetail(int $taskId): array
+    {
+        $task = $this->getTask($taskId);
+        if (!$task) {
+            throw new ValidateException('推广任务不存在');
+        }
+        return $this->decorateTask($task);
+    }
+
+    public function records(int $taskId, int $uid = 0): array
+    {
+        return $this->recordDao->getTaskRecords($taskId, $uid);
+    }
+
+    public function amountLogs(int $uid, int $page, int $limit): array
+    {
+        return $this->amountLogDao->getUserList($uid, $page, $limit);
+    }
+
+    public function refreshRewardStatus(int $taskId): void
+    {
+        $trigger = $this->triggerDao->getOne(['task_id' => $taskId]);
+        if (!$trigger) {
+            return;
+        }
+        $failed = in_array(2, [(int)$trigger['points_status'], (int)$trigger['level_task_status'], (int)$trigger['brokerage_status']], true);
+        $success = (int)$trigger['points_status'] === 1 && (int)$trigger['level_task_status'] === 1 && (int)$trigger['brokerage_status'] === 1;
+        $this->taskDao->update($taskId, ['reward_trigger_status' => $success ? 1 : ($failed ? 2 : 3)]);
+    }
+
+    private function createTask(int $uid, array $order, int $splitIndex, array $config): array
+    {
+        $taskNo = 'SYJ' . date('YmdHis') . $uid . str_pad((string)$splitIndex, 2, '0', STR_PAD_LEFT) . mt_rand(100, 999);
+        $row = $this->taskDao->save([
+            'uid' => $uid,
+            'task_no' => $taskNo,
+            'source_order_id' => (int)$order['id'],
+            'source_order_no' => (string)$order['order_id'],
+            'source_split_index' => $splitIndex,
+            'base_amount' => $config['base_amount'],
+            'reward_rates' => json_encode($config['reward_rates'], JSON_UNESCAPED_UNICODE),
+            'fee_rate' => $config['early_cashout_fee_rate'],
+            'status' => 0,
+            'progress_count' => 0,
+            'target_count' => $config['target_count'],
+            'reward_trigger_status' => 3,
+            'reward_trigger_no' => $taskNo,
+        ])->toArray();
+        try {
+            app()->make(SyjPromoteRewardTriggerServices::class)->triggerForTask($row);
+            $this->refreshRewardStatus((int)$row['id']);
+        } catch (\Throwable $e) {
+            Log::error('[SYJ] 任务奖励触发异常 task=' . $row['id'] . ' ' . $e->getMessage());
+            $this->taskDao->update((int)$row['id'], ['reward_trigger_status' => 2, 'exception_reason' => $e->getMessage()]);
+        }
+        return $row;
+    }
+
+    private function lockUserAmount(int $uid): array
+    {
+        $row = $this->userAmountDao->lockByUid($uid);
+        if (!$row) {
+            $this->userAmountDao->save(['uid' => $uid, 'pending_amount' => '0.00']);
+            $row = $this->userAmountDao->lockByUid($uid);
+        }
+        return $row;
+    }
+
+    private function isQueueOrder(array $order): bool
+    {
+        return !empty($order['is_queue_goods']) && empty($order['is_del']) && empty($order['is_system_del']) && (int)($order['paid'] ?? 1) === 1;
+    }
+
+    private function validAmount(array $order): string
+    {
+        $pay = (string)($order['pay_price'] ?? '0');
+        $refund = (string)($order['refund_price'] ?? '0');
+        $amount = bcsub($pay, $refund, 2);
+        return bccomp($amount, '0', 2) > 0 ? $amount : '0.00';
+    }
+
+    private function decorateTask(array $task): array
+    {
+        $task['records'] = $this->recordDao->getTaskRecords((int)$task['id']);
+        $task['settlement'] = ($this->settlementDao->getOne(['task_id' => (int)$task['id']]) ?: null)?->toArray();
+        $task['reward_trigger'] = ($this->triggerDao->getOne(['task_id' => (int)$task['id']]) ?: null)?->toArray();
+        return $task;
+    }
+
+    private function availableCashoutAmount(int $uid): string
+    {
+        $tasks = $this->taskDao->getCashoutAvailableTasks($uid);
+        $total = '0.00';
+        foreach ($tasks as $task) {
+            $rates = json_decode((string)$task['reward_rates'], true) ?: [10, 20, 30, 40];
+            $rate = (float)($rates[((int)$task['progress_count']) - 1] ?? 0);
+            $gross = bcmul((string)$task['base_amount'], bcdiv((string)$rate, '100', 4), 2);
+            $fee = bcmul($gross, bcdiv((string)$task['fee_rate'], '100', 4), 2);
+            $total = bcadd($total, bcsub($gross, $fee, 2), 2);
+        }
+        return $total;
+    }
+
+    private function money(float|string $amount): string
+    {
+        return number_format((float)$amount, 2, '.', '');
+    }
+}