feat(profits): 实现合伙人分红功能

- 新增合伙人分红相关的模型、DAO和控制器
- 实现了获取0号线用户、计算分红、记录日志等核心功能
- 添加了队列任务处理和日志记录机制

app/common/dao/BaseDao.php

@@ -170,6 +170,11 @@ abstract class BaseDao
         return ($this->getModel())::getInstance()->where($where)->field($field)->select();
     }
 
+    public function selectWhereIn(string $whereField, array $where, string $field = '*')
+    {
+        return ($this->getModel())::getInstance()->whereIn($whereField,$where)->field($field)->select();
+    }
+
     /**
      * @param int $id
      * @param array $with

app/common/dao/profit/ZeroUserProfitDao.php

@@ -0,0 +1,25 @@
+<?php
+
+namespace app\common\dao\profit;
+
+use app\common\dao\BaseDao;
+use app\common\model\profit\ZeroUserProfits;
+
+class ZeroUserProfitDao extends BaseDao
+{
+
+    protected function getModel(): string
+    {
+        return ZeroUserProfits::class;
+    }
+
+    /**
+     * @param $data
+     * @return mixed
+     * 插入数据并获取id
+     */
+    public function insertGetId($data)
+    {
+        return $this->getModel()::getDB()->insertGetId($data);
+    }
+}

app/common/dao/profit/ZeroUserProfitDetailDao.php

@@ -0,0 +1,15 @@
+<?php
+
+namespace app\common\dao\profit;
+
+use app\common\dao\BaseDao;
+use app\common\model\profit\ZeroUserProfitsDetail;
+
+class ZeroUserProfitDetailDao extends BaseDao
+{
+
+    protected function getModel(): string
+    {
+        return ZeroUserProfitsDetail::class;
+    }
+}

app/common/dao/store/order/OldUserOfGoodsDao.php

@@ -0,0 +1,35 @@
+<?php
+
+namespace app\common\dao\store\order;
+
+use app\common\dao\BaseDao;
+use app\common\model\store\order\OldUserOfGoods;
+
+class OldUserOfGoodsDao extends BaseDao
+{
+
+    protected function getModel(): string
+    {
+        return OldUserOfGoods::class;
+    }
+
+    /**
+     * @param $userId
+     * @param $price
+     * @return array
+     * 获取业绩
+     */
+    public function getPv($userId, $price)
+    {
+        $model = $this->getModel();
+        $oldPvData = $model::getDB()
+            ->whereIn('user_id', $userId)
+            ->whereIn('money', $price)
+            ->where('status', 1)
+            ->group('money')
+            ->field('money,count(1) as count')
+            ->select()
+            ->toArray();
+        return array_column($oldPvData,'count','money');
+    }
+}

app/common/dao/store/order/StoreOrderDao.php

@@ -630,4 +630,26 @@ class StoreOrderDao extends BaseDao
         }
         return $entityList;
     }
+
+    /**
+     * @param $userId
+     * @param $price
+     * @return array
+     * 获取pv
+     */
+    public function getPv($userId, $price)
+    {
+        $model = $this->getModel();
+        $oldPvData = $model::getDB()
+            ->where('mer_id', 496)
+            ->whereIn('uid', $userId)
+            ->whereIn('total_price', $price)
+            ->whereIn('status', [0, 1, 2, 3])
+            ->whereNotNull("pay_time")
+            ->group('total_price')
+            ->field('total_price,count(1) as count')
+            ->select()
+            ->toArray();
+        return array_column($oldPvData,'count','total_price');
+    }
 }

app/common/dao/user/UserDao.php

@@ -456,4 +456,18 @@ class UserDao extends BaseDao
     {
         return $this::getModel()::getDB()->where('level_id', '=', $userId)->column('uid');
     }
+
+    /**
+     * @param $uids
+     * @param $userGroup
+     * @return array
+     * @throws DataNotFoundException
+     * @throws DbException
+     * @throws ModelNotFoundException
+     * 通过user_group获取用户
+     */
+    public function getUsersByGroup($uids,$userGroup)
+    {
+        return $this::getModel()::getDB()->whereIn('uid', $uids)->where(['user_group'=>$userGroup])->column('uid');
+    }
 }

app/common/model/profit/ZeroUserProfits.php

@@ -0,0 +1,19 @@
+<?php
+
+namespace app\common\model\profit;
+
+use app\common\model\BaseModel;
+
+class ZeroUserProfits extends BaseModel
+{
+
+    public static function tablePk(): ?string
+    {
+        return 'id';
+    }
+
+    public static function tableName(): string
+    {
+        return 'zero_user_profits';
+    }
+}

app/common/model/profit/ZeroUserProfitsDetail.php

@@ -0,0 +1,21 @@
+<?php
+
+namespace app\common\model\profit;
+
+use app\common\model\BaseModel;
+
+class ZeroUserProfitsDetail extends BaseModel
+{
+    private static $tablePk = 'id';
+    private static $tableName = 'zero_user_profit_detail';
+
+    public static function tablePk(): ?string
+    {
+        return self::$tablePk;
+    }
+
+    public static function tableName(): string
+    {
+        return self::$tableName;
+    }
+}

app/common/model/store/order/OldUserOfGoods.php

@@ -0,0 +1,20 @@
+<?php
+
+namespace app\common\model\store\order;
+
+
+
+use app\common\model\BaseModel;
+
+class OldUserOfGoods extends BaseModel
+{
+    public static function tablePk(): ?string
+    {
+        return 'id';
+    }
+
+    public static function tableName(): string
+    {
+        return 'old_user_of_goods';
+    }
+}

app/common/repositories/profits/ProfitsRepository.php

@@ -0,0 +1,374 @@
+<?php
+
+namespace app\common\repositories\profits;
+
+
+use app\common\dao\profit\ZeroUserProfitDao;
+use app\common\dao\store\order\OldUserOfGoodsDao;
+use app\common\dao\store\order\StoreOrderDao;
+use app\common\dao\user\UserDao;
+use app\common\dao\user\ZeroUserLineDao;
+use app\common\enum\user\ZeroUserEnum;
+use app\common\model\profit\ZeroUserProfitsDetail;
+use app\jobs\ZeroUserProfits;
+use think\db\exception\DataNotFoundException;
+use think\db\exception\DbException;
+use think\db\exception\ModelNotFoundException;
+use think\facade\Db;
+
+class ProfitsRepository
+{
+    // 初级合伙人id
+    const BASIC = 4;
+    // 初级合伙人佣金比例
+    const BASIC_PERCENT = 0.15;
+
+    // 中级合伙人id
+    const MIDDLE = 5;
+    // 中级合伙人佣金比例
+    const MIDDLE_PERCENT = 0.15;
+
+    // 高级合伙人id
+    const HIGH = 6;
+    // 高级合伙人佣金比例
+    const HIGH_PERCENT = 0.15;
+
+    // 合伙人数据映射
+    private $parents = [
+        self::BASIC => self::BASIC_PERCENT,
+        self::MIDDLE => self::MIDDLE_PERCENT,
+        self::HIGH => self::HIGH_PERCENT,
+    ];
+
+    // 业绩数据映射（pv）
+    private $pv = [
+        1180 => 700,
+        11800 => 7000,
+        10620 => 6300,
+        9440 => 5600,
+        2360 => 1400
+    ];
+
+    // 用户
+    private $userDao;
+
+    // 订单（老）
+    // private $oldUserOfGoodsDao;
+
+    // 订单（新）
+    // private $storeOrder;
+
+    public function __construct()
+    {
+        $this->userDao = new UserDao();
+        // $this->oldUserOfGoodsDao = new OldUserOfGoodsDao();
+        // $this->storeOrder = new StoreOrderDao();
+    }
+
+    /**
+     * @param $param
+     * @return string|true
+     * @throws DataNotFoundException
+     * @throws DbException
+     * @throws ModelNotFoundException
+     * 获取需要分红的0号线用户并加入队列
+     */
+    public function getZeroUser($param)
+    {
+        $zeroUserId = $param['zeroUserId'];
+        // 0号线用户id是0的时候，获取全部0号线用户
+        if ($zeroUserId == 0) {
+            $zeroUserId = $this->getAllZeroUserIds();
+        }
+        if (is_string($zeroUserId)) {
+            $zeroUserId = explode(',', $zeroUserId);
+        }
+
+        // 拼接队列需要的数据
+        $queueData = [
+            'startTime' => $param['startTime'],
+            'endTime' => $param['endTime'],
+            'is_test' => $param['isTest'],
+            'amount' => $param['amount']
+        ];
+
+        // 记录日志
+        $insertData = [
+            'start_time' => $param['startTime'],
+            'end_time' => $param['endTime'],
+            'is_test' => $param['isTest'],
+            'amount' => $param['amount']
+        ];
+        $dao = new ZeroUserProfitDao();
+        // 加入队列
+        try {
+            foreach ($zeroUserId as $value) {
+                $insertData['user_id'] = $value;
+                $logId = $dao->insertGetId($insertData);
+
+                $queueData['zeroUserId'] = $value;
+                $queueData['logId'] = $logId;
+
+                queue(ZeroUserProfits::class, $queueData, 0, 'zeroProfit');
+            }
+            return true;
+        } catch (\Exception $e) {
+            return $e->getMessage();
+        }
+
+
+    }
+
+    /**
+     * @throws DataNotFoundException
+     * @throws ModelNotFoundException
+     * @throws DbException
+     * 执行分红
+     */
+    public function profits($param)
+    {
+        try {
+            // 获取0号线用户的所有下级用户
+            $userIds = $this->getAllUser($param['zeroUserId']);
+            // 获取分红总额(业绩)
+            $amount = $param['amount'];
+            if ($param['amount'] == 0) {
+                $amount = $this->getAmount($userIds);
+            }
+
+            // 计算分红
+            $directUids = [];
+            foreach ($this->parents as $key => $value) {
+                // 获取初，中，高用户
+                unset($groupData);
+                $groupData = $this->getUserByGroup($userIds, $key);
+                if (!empty($groupData)) {
+                    // 获取初中高用户直推和团队业绩
+                    $profitDetail = $this->getDirect($groupData, $amount * $value);
+                    $directUids[$key] = $profitDetail;
+                    $this->recordLog($param, $amount, $profitDetail);
+                }
+            }
+            return true;
+        } catch (\Exception $e) {
+            return false;
+        }
+    }
+
+    /**
+     * @param $param
+     * @return array
+     * 获取要分红的用户ids
+     */
+    private function getUserIds($param): array
+    {
+
+        $res = $this->getAllZeroUser($param['zeroUserId']);
+        return $res;
+    }
+
+    /**
+     * @return array
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     * 获取所有下级用户
+     */
+    private function getAllUser($zeroUid)
+    {
+
+        $sql = "select getUserLevelId($zeroUid) as teamUids";
+        $teamUids = Db::query($sql)[0]['teamUids'];
+        // $resArr[$zeroUid] = $teamUids;
+        return $teamUids;
+    }
+
+    /**
+     * @return array
+     * @throws DataNotFoundException
+     * @throws DbException
+     * @throws ModelNotFoundException
+     * 获取全部0号线用户
+     */
+    private function getAllZeroUserIds()
+    {
+        $zeroUserDao = new ZeroUserLineDao();
+        $zeroUserIds = $zeroUserDao->selectWhere([
+            'is_remove' => ZeroUserEnum::IS_REMOVE_MAP['YES']['code'],
+            'status' => ZeroUserEnum::STATUS_MAP['NORMAL']['code']
+        ])->column('team_uid');
+
+        if (empty($zeroUserIds)) {
+            return [];
+        }
+
+        // // 循环获取0号线用户团队
+        // $resArr = [];
+        // foreach ($zeroUserIds as $zeroUserId) {
+        //     $zeroUid = $zeroUserId['team_uid'];
+        //     $sql = "select getUserLevelId($zeroUid) as teamUids";
+        //     $teamUids = Db::query($sql)[0]['teamUids'];
+        //     $resArr[$zeroUid] = $teamUids;
+        // }
+
+        return $zeroUserIds;
+    }
+
+    /**
+     * @param $userIds
+     * @return int
+     * 获取分红总额
+     */
+    private function getAmount($userIds): int
+    {
+        return 10000;
+    }
+
+    /**
+     * @param $uids
+     * @param $userGroup
+     * @return array
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     * 获取符合合伙人等级的用户
+     */
+    private function getUserByGroup($uid, $userGroup): array
+    {
+        $userDao = new UserDao();
+        return $userDao->getUsersByGroup($uid, $userGroup);
+    }
+
+    /**
+     * @param $data
+     * @return array
+     * @throws DataNotFoundException
+     * @throws DbException
+     * @throws ModelNotFoundException
+     * 获取直推用户业绩
+     */
+    private function getDirect($data, $amount): array
+    {
+
+
+        $money = $amount / 2;
+        $res = [];
+        foreach ($data as $key => $value) {
+            if (empty($value)) {
+                unset($data[$key]);
+                continue;
+            }
+
+            // 获取直推
+            $directUids = $this->userDao->selectWhere(['level_id' => $value])->column('uid');
+
+
+            // 获取直推用户pv
+            $pvArr = $this->getPv($directUids);
+            $all = 0;
+            $all += array_sum($pvArr);
+            $max = max($pvArr);
+            $min = $all - $max;
+            $res[$value]['all'] = $all;
+            $res[$value]['min'] = $min;
+            $res[$value]['max'] = $max;
+        }
+        $res = $this->countPrice($res, $money);
+        return $res;
+    }
+
+    /**
+     * @param $directUids
+     * @param $pvConfig
+     * @return array
+     * 计算pv
+     */
+    private function getPv($directUids)
+    {
+        $res = [];
+        foreach ($directUids as $uid) {
+            // 获取直推用户的团队uid
+            $teamUids = $this->getTeamUids($uid);
+            // 去除自己
+            $teamUids = array_slice($teamUids, 1);
+            // 获取团队的pv
+            $pvArr = $this->userDao->selectWhereIn('uid', $teamUids)->column('pv', 'uid');
+            if (($pvArr)) {
+                $all = array_sum($pvArr);
+                $res[$uid] = $all;
+            }
+        }
+        return $res;
+    }
+
+    /**
+     * @param $uid
+     * @return mixed
+     * 获取团队所有人uids  [1,2,3]
+     */
+    private function getTeamUids($uid): array
+    {
+        $sql = "select getUserLevelId($uid) as uids";
+        return explode(',', Db::query($sql)[0]['uids']);
+    }
+
+    /**
+     * @param $pvArr
+     * @param $money
+     * @return mixed
+     * 计算分佣
+     */
+    private function countPrice($pvArr, $money)
+    {
+        $minAll = array_sum(array_column($pvArr, 'min'));
+        $maxAll = array_sum(array_column($pvArr, 'all'));
+        foreach ($pvArr as $k => $v) {
+            $pvArr[$k]['minCount'] = floor($money * ($v['min'] / $minAll) * 100) / 100;
+            $pvArr[$k]['maxCount'] = floor($money * ($v['all'] / $maxAll) * 100) / 100;
+        }
+
+        return $pvArr;
+    }
+
+    /**
+     * @param $param
+     * @param $amount
+     * @param $detail
+     * @return string|true
+     * 记录日志
+     */
+    private function recordLog($param, $amount, $detail)
+    {
+        $logDao = new ZeroUserProfitDao();
+        $detailDao = new ZeroUserProfitsDetail();
+        // 记录分红明细日志，修改主表数据
+        $updateData = [
+            'amount' => $amount,
+            'status' => 1
+        ];
+
+        foreach ($detail as $key => $value) {
+            $insertData = [
+                'zero_user_profit_id' => $param['logId'],
+                'zero_user_id' => $param['zeroUserId'],
+                'user_id' => $key,
+                'amount' => $amount,
+                'all' => $value['all'],
+                'min' => $value['min'],
+                'max' => $value['max'],
+                'min_count' => $value['minCount'],
+                'max_count' => $value['maxCount'],
+            ];
+            try {
+                Db::startTrans();
+                $logDao->update($param['logId'], $updateData);
+                $detailDao->create($insertData);
+                Db::commit();
+            } catch (\Exception $e) {
+                Db::rollback();
+                return $e->getMessage();
+            }
+        }
+        return true;
+    }
+}

app/common/utils/QueueLogger.php

@@ -0,0 +1,202 @@
+<?php
+
+namespace app\common\utils;
+
+use think\facade\Log;
+use think\console\Output;
+
+/**
+ * 队列日志工具类
+ * 提供统一的队列任务日志记录功能
+ */
+class QueueLogger
+{
+    /**
+     * 记录队列任务开始日志
+     *
+     * @param string $jobName 任务名称
+     * @param mixed $job 任务对象
+     * @param array $data 任务数据
+     */
+    public static function start($jobName, $job, $data)
+    {
+        $logData = [
+            'job_id' => method_exists($job, 'getJobId') ? $job->getJobId() : 'unknown',
+            'data' => $data,
+            'attempts' => method_exists($job, 'attempts') ? $job->attempts() : 0,
+            'start_time' => date('Y-m-d H:i:s')
+        ];
+        
+        Log::channel('queue')->info("{$jobName}任务开始执行", $logData);
+        self::outputToCli("{$jobName}任务开始执行", $logData);
+    }
+
+    /**
+     * 记录队列任务成功日志
+     *
+     * @param string $jobName 任务名称
+     * @param mixed $job 任务对象
+     * @param array $data 任务数据
+     * @param mixed $result 执行结果
+     */
+    public static function success($jobName, $job, $data, $result = null)
+    {
+        $logData = [
+            'job_id' => method_exists($job, 'getJobId') ? $job->getJobId() : 'unknown',
+            'data' => $data,
+            'result' => $result,
+            'end_time' => date('Y-m-d H:i:s')
+        ];
+        
+        Log::channel('queue')->info("{$jobName}任务执行成功", $logData);
+        self::outputToCli("{$jobName}任务执行成功", $logData);
+    }
+
+    /**
+     * 记录队列任务警告日志
+     *
+     * @param string $jobName 任务名称
+     * @param mixed $job 任务对象
+     * @param array $data 任务数据
+     * @param string $message 警告信息
+     */
+    public static function warning($jobName, $job, $data, $message)
+    {
+        $logData = [
+            'job_id' => method_exists($job, 'getJobId') ? $job->getJobId() : 'unknown',
+            'data' => $data,
+            'attempts' => method_exists($job, 'attempts') ? $job->attempts() : 0
+        ];
+        
+        Log::channel('queue')->warning("{$jobName}任务警告: {$message}", $logData);
+        self::outputToCli("{$jobName}任务警告: {$message}", $logData, 'warning');
+    }
+
+    /**
+     * 记录队列任务异常日志
+     *
+     * @param string $jobName 任务名称
+     * @param mixed $job 任务对象
+     * @param array $data 任务数据
+     * @param \Exception $e 异常对象
+     */
+    public static function error($jobName, $job, $data, \Exception $e)
+    {
+        $logData = [
+            'data' => $data,
+            'error_message' => $e->getMessage(),
+            'error_file' => $e->getFile(),
+            'error_line' => $e->getLine(),
+            'error_trace' => $e->getTraceAsString()
+        ];
+        
+        // 安全地获取job信息，避免方法不存在导致的错误
+        if (is_object($job)) {
+            if (method_exists($job, 'getJobId')) {
+                $logData['job_id'] = $job->getJobId();
+            }
+            if (method_exists($job, 'attempts')) {
+                $logData['attempts'] = $job->attempts();
+            }
+        }
+        
+        Log::channel('queue')->error("{$jobName}任务执行异常", $logData);
+        self::outputToCli("{$jobName}任务执行异常: " . $e->getMessage(), $logData, 'error');
+    }
+
+    /**
+     * 记录队列任务失败日志
+     *
+     * @param string $jobName 任务名称
+     * @param array $data 任务数据
+     * @param string $message 失败信息
+     */
+    public static function failed($jobName, $data, $message = '任务进入失败状态，需要手动处理')
+    {
+        $logData = [
+            'data' => $data,
+            'failed_time' => date('Y-m-d H:i:s'),
+            'message' => $message
+        ];
+        
+        Log::channel('queue')->error("{$jobName}任务失败", $logData);
+        self::outputToCli("{$jobName}任务失败: {$message}", $logData, 'error');
+    }
+
+    /**
+     * 记录队列任务结束日志
+     *
+     * @param string $jobName 任务名称
+     * @param mixed $job 任务对象
+     * @param array $data 任务数据
+     */
+    public static function end($jobName, $job, $data)
+    {
+        $logData = [
+            'job_id' => method_exists($job, 'getJobId') ? $job->getJobId() : 'unknown',
+            'data' => $data,
+            'end_time' => date('Y-m-d H:i:s')
+        ];
+        
+        Log::channel('queue')->info("{$jobName}任务执行结束", $logData);
+        self::outputToCli("{$jobName}任务执行结束", $logData);
+    }
+
+    /**
+     * 记录业务执行开始日志
+     *
+     * @param string $businessName 业务名称
+     * @param array $data 业务数据
+     */
+    public static function businessStart($businessName, $data)
+    {
+        $logData = [
+            'data' => $data,
+            'start_time' => date('Y-m-d H:i:s')
+        ];
+        
+        Log::channel('queue')->info("开始执行{$businessName}业务", $logData);
+        self::outputToCli("开始执行{$businessName}业务", $logData);
+    }
+
+    /**
+     * 记录队列任务信息日志
+     *
+     * @param string $message 日志信息
+     * @param array $context 上下文数据
+     */
+    public static function info($message, array $context = [])
+    {
+        Log::channel('queue')->info($message, $context);
+        self::outputToCli($message, $context);
+    }
+
+    /**
+     * 输出到CLI命令行
+     *
+     * @param string $message 消息内容
+     * @param array $context 上下文数据
+     * @param string $level 日志级别
+     */
+    private static function outputToCli($message, $context = [], $level = 'info')
+    {
+        if (PHP_SAPI === 'cli') {
+            $output = new Output();
+            $timestamp = date('Y-m-d H:i:s');
+            
+            switch ($level) {
+                case 'error':
+                    $prefix = 'ERROR';
+                    $output->error("[{$timestamp}] [{$prefix}] {$message}");
+                    break;
+                case 'warning':
+                    $prefix = 'WARN';
+                    $output->warning("[{$timestamp}] [{$prefix}] {$message}");
+                    break;
+                default:
+                    $prefix = 'INFO';
+                    $output->info("[{$timestamp}] [{$prefix}] {$message}");
+            }
+        }
+    }
+}

app/controller/admin/profits/ShareProfits.php

@@ -0,0 +1,45 @@
+<?php
+
+namespace app\controller\admin\profits;
+
+use app\common\repositories\profits\ProfitsRepository;
+use app\controller\admin\BaseController;
+use app\entity\admin\request\profits\PartnerProfitsRequestEntity;
+use app\entity\admin\response\profits\ZeroUserProfitResponseEntity;
+use app\validate\admin\profits\PartnerProfitsValidate;
+
+class ShareProfits extends BaseController
+{
+    /**
+     * @var
+     */
+    private $repository;
+
+    public function __construct(ProfitsRepository $repository)
+    {
+        parent::__construct();
+        $this->repository = $repository;
+    }
+
+
+    /**
+     * @param  PartnerProfitsValidate  $validate
+     * @return mixed
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     * 合伙人分红接口
+     */
+    public function partnerProfits(PartnerProfitsValidate $validate)
+    {
+        $validationResult = $this->validateRequest($validate, PartnerProfitsRequestEntity::class);
+        $res = $this->repository->getZeroUser($validationResult->toArray());
+        // $res = $this->repository->profits($validationResult->toArray());
+        if (is_string($res)) {
+            $response = ZeroUserProfitResponseEntity::error($res);
+            return app('json')->fail($response->toResponseArray());
+        }
+        $response = ZeroUserProfitResponseEntity::success();
+        return app('json')->success($response->toResponseArray());
+    }
+}

app/entity/admin/request/profits/PartnerProfitsRequestEntity.php

@@ -0,0 +1,118 @@
+<?php
+
+namespace app\entity\admin\request\profits;
+
+use app\entity\request\RequestCommonEntity;
+
+/**
+ * 合伙人收益请求参数
+ */
+class PartnerProfitsRequestEntity extends RequestCommonEntity
+{
+
+    // 开始时间
+    public $startTime;
+
+    // 结束时间
+    public $endTime;
+
+    // 是否发放分红
+    public $isTest;
+
+    // 金额
+    public $amount;
+
+    public $isZero;
+
+    // 0号线用户ID
+    public $zeroUserId;
+
+    public $type;
+
+    // 获取开始时间
+    public function getStartTime()
+    {
+        return $this->startTime;
+    }
+
+    // 设置开始时间
+    public function setStartTime($startTime): PartnerProfitsRequestEntity
+    {
+        $this->startTime = $startTime;
+        return $this;
+    }
+
+    // 获取结束时间
+    public function getEndTime()
+    {
+        return $this->endTime;
+    }
+
+    // 设置结束时间
+    public function setEndTime($endTime): PartnerProfitsRequestEntity
+    {
+        $this->endTime = $endTime;
+        return $this;
+    }
+
+    // 获取是否测试
+    public function getIsTest()
+    {
+        return $this->isTest;
+    }
+
+    // 设置是否测试
+    public function setIsTest($isTest): PartnerProfitsRequestEntity
+    {
+        $this->isTest = $isTest;
+        return $this;
+    }
+
+    // 获取金额是否为零
+    public function getAmount()
+    {
+        return $this->amount;
+    }
+
+    // 设置金额是否为零
+    public function setAmount($amount): PartnerProfitsRequestEntity
+    {
+        $this->amount = $amount;
+        return $this;
+    }
+
+    public function getIsZero()
+    {
+        return $this->isZero;
+    }
+
+    public function setIsZero($isZero): PartnerProfitsRequestEntity
+    {
+        $this->isZero = $isZero;
+        return $this;
+    }
+
+    // 获取零用户ID
+    public function getZeroUserId()
+    {
+        return $this->zeroUserId;
+    }
+
+    // 设置零用户ID
+    public function setZeroUserId($zeroUserId): PartnerProfitsRequestEntity
+    {
+        $this->zeroUserId = $zeroUserId;
+        return $this;
+    }
+
+    public function getType()
+    {
+        return $this->type;
+    }
+
+    public function setType($type): PartnerProfitsRequestEntity
+    {
+        $this->type = $type;
+        return $this;
+    }
+}

app/entity/admin/response/profits/ZeroUserProfitResponseEntity.php

@@ -0,0 +1,32 @@
+<?php
+
+namespace app\entity\admin\response\profits;
+
+use app\entity\admin\response\AdminCommonResponseEntity;
+
+class ZeroUserProfitResponseEntity extends AdminCommonResponseEntity
+{
+    /**
+     * 创建零号线用户操作成功响应
+     * @param  null  $data
+     * @param  string  $message
+     * @param  int  $code
+     * @return AdminCommonResponseEntity
+     */
+    public static function success(string $message = '操作成功', int $code = 200, $data = null): AdminCommonResponseEntity
+    {
+        return parent::success($message);
+    }
+
+    /**
+     * 创建零号线用户操作失败响应
+     * @param  string  $message
+     * @param  int  $code
+     * @param  null  $data
+     * @return AdminCommonResponseEntity
+     */
+    public static function error(string $message = '操作失败', int $code = 400, $data = null): AdminCommonResponseEntity
+    {
+        return parent::error($message, $code);
+    }
+}

app/jobs/ZeroUserProfits.php

@@ -0,0 +1,82 @@
+<?php
+
+namespace app\jobs;
+
+
+
+use app\common\model\profit\ZeroUserProfits as ZeroUserProfitsModel;
+use app\common\repositories\profits\ProfitsRepository;
+use app\common\utils\QueueLogger;
+use crmeb\interfaces\JobInterface;
+
+class ZeroUserProfits implements JobInterface
+{
+    public function fire($job, $data)
+    {
+        // 记录任务开始日志
+        QueueLogger::start('ZeroUserProfits', $job, $data);
+
+        // 数据仓库
+        $repository = new ProfitsRepository();
+        try {
+            // 记录业务执行开始
+            QueueLogger::businessStart('用户收益计算', $data);
+            
+            // 执行业务
+            $res = $repository->profits($data);
+            
+            if ($res) {
+                // 记录成功日志
+                QueueLogger::success('ZeroUserProfits', $job, $data, $res);
+                $job->delete();
+            } else {
+                // 记录业务执行失败但未异常的情况
+                QueueLogger::warning('ZeroUserProfits', $job, $data, '业务执行返回false');
+                
+                if ($job->attempts() > 3) {
+                    // 超过重试次数，调用failed方法记录异常状态
+                    $this->failed($data);
+                    $job->delete();
+                }
+            }
+        } catch (\Exception $e) {
+            // 记录异常日志
+            QueueLogger::error('ZeroUserProfits', $job, $data, $e);
+            
+            if ($job->attempts() > 3) {
+                // 超过重试次数，调用failed方法记录异常状态
+                $this->failed($data);
+                $job->delete();
+            }
+        }
+        
+        // 记录任务结束日志
+        QueueLogger::end('ZeroUserProfits', $job, $data);
+    }
+
+    public function failed($data)
+    {
+        try {
+            // 记录任务失败日志
+            QueueLogger::failed('ZeroUserProfits', $data);
+            
+            // 在数据库中标记数据异常状态
+            if (isset($data['logId']) && !empty($data['logId'])) {
+                // 更新ZeroUserProfits表的status字段为异常状态
+                ZeroUserProfitsModel::where('id', $data['logId'])
+                    ->update([
+                        'status' => 3, // 假设2表示异常状态
+                        'update_time' => time()
+                    ]);
+                
+                QueueLogger::info('ZeroUserProfits任务失败状态已更新', [
+                    'data_id' => $data['logId'],
+                    'status' => 2
+                ]);
+            }
+        } catch (\Exception $e) {
+            // 记录数据库更新异常
+            QueueLogger::error('ZeroUserProfits任务失败状态更新异常', null, $data, $e);
+        }
+    }
+}

app/validate/admin/profits/PartnerProfitsValidate.php

@@ -0,0 +1,27 @@
+<?php
+
+namespace app\validate\admin\profits;
+
+use app\validate\CommonValidate;
+
+class PartnerProfitsValidate extends CommonValidate
+{
+    protected $failException = true;
+
+    protected $rule = [
+        'start_time|开始时间' => 'date',
+        'end_time|结束时间' => 'date',
+        'is_test|是否发放' => 'in:0,1',
+        'amount｜分红总金额' => 'number',
+        'is_zero|是否0号线分红' => 'in:0,1',
+    ];
+
+    protected $message = [
+        'start_time.date' => '请选择开始时间',
+        'end_time.date' => '请选择结束时间',
+        'is_test.required' => '请选择是否发放' ,
+        'amount.number' => '分红总金额必须为数字',
+        'is_zero.required' => '请选择是否0号线分红',
+        'is_zero.integer' => '非法0号线分红'
+    ];
+}

config/log.php

@@ -47,6 +47,17 @@ return [
             'path' => app()->getRootPath().'runtime/gong',
             'time_format' => 'Y-m-d H:i:s',
             'format' => '[%s][%s]:%s'
+        ],
+        // 队列任务专用日志通道
+        'queue' => [
+            'type' => 'File',
+            'path' => app()->getRootPath().'runtime/queue',
+            'time_format' => 'Y-m-d H:i:s',
+            'format' => '[%s][%s] %s',
+            'single' => false,
+            'max_files' => 30,
+            'file_size' => 1024 * 1024 * 1024,
+            'realtime_write' => true,
         ]
     ],
 

crmeb/services/SwooleTaskService.php

@@ -49,7 +49,12 @@ class SwooleTaskService
     public function __construct(string $type)
     {
         $this->type = $type;
-        $this->server = app('swoole.server');
+        // 只有在Swoole扩展已加载且swoole.server服务存在时才获取server实例
+        if (extension_loaded('swoole') && app()->has('swoole.server')) {
+            $this->server = app('swoole.server');
+        } else {
+            $this->server = null;
+        }
     }
 
     /**
@@ -74,8 +79,14 @@ class SwooleTaskService
     public function push(int $workId = -1)
     {
         try {
-
-            return $this->server->task(['type' => $this->type, 'data' => $this->data], $workId);
+            // 只有在有Swoole服务器实例时才发送任务
+            if ($this->server instanceof \Swoole\Server) {
+                return $this->server->task(['type' => $this->type, 'data' => $this->data], $workId);
+            } else {
+                // 非Swoole环境下记录日志但不抛出异常
+                Log::info('Swoole服务器不可用，任务未发送: ' . $this->type);
+                return false;
+            }
         } catch (\Exception $e) {
             Log::info('发送 Task 失败' . $e->getMessage());
         }