fix: 抽奖记录

application/api/controller/Lottery.php

@@ -151,9 +151,6 @@ class Lottery extends Api
         $activityId = $this->request->post('lottery_id/d');
         $userId = $this->auth->id;
         $result = LotteryService::drawLottery($activityId, $userId);
-
-        // 处理图片
-        $result['prize']['image'] = cdnurl($result['prize']['image']);
         $this->success('抽奖成功', $result);
     }
 
@@ -191,18 +188,21 @@ class Lottery extends Api
             $validateParams['activity_id_optional'] = $params['lottery_id'];
             unset($validateParams['lottery_id']);
         }
-        
+        if (isset($params['status'])) {
+            $validateParams['record_status'] = $params['status'];
+            unset($validateParams['status']);
+        }        
         if (!$validate->scene('getDrawRecords')->check($validateParams)) {
             $this->error($validate->getError());
         }
 
         $activityId = $this->request->post('lottery_id/d');
         $page = $this->request->param('page/d', 1);
-        $pageSize = $this->request->param('pageSize/d', 20);
-
+        $pageSize = $this->request->param('pageSize/d', 10);
+        $status =  $params['status'] ?? 1;
         $userId = $this->auth->id;
         
-        $records = LotteryRecordService::getUserDrawRecords($userId, $activityId, $page, $pageSize);
+        $records = LotteryRecordService::getUserDrawRecords($userId, $activityId,  $status, $page, $pageSize);
         $this->success('获取成功',  $records);
     }
 

application/api/validate/Lottery.php

@@ -3,9 +3,16 @@
 namespace app\api\validate;
 
 use think\Validate;
-
+use app\common\Enum\LotteryEnum;
 class Lottery extends Validate
 {
+
+    public function __construct(array $rules = [], $message = [], $field = [])
+    {
+        // 动态设置枚举值
+        $this->rule['record_status'] = 'require|in:' . implode(',', LotteryEnum::getDrawStatusList());
+        parent::__construct($rules, $message, $field);
+    }
     /**
      * 验证规则
      */
@@ -13,7 +20,7 @@ class Lottery extends Validate
         'lottery_id'           => 'require|integer|gt:0',
         'lottery_id_optional'  => 'integer|gt:0',  // 可选的lottery_id
         'page'                  => 'integer|egt:1',
-        'limit'                 => 'integer|between:1,100',
+        'pageSize'              => 'integer|between:1,100',
         'status'                => 'integer|in:0,1,2,3',
         'type'                  => 'array|length:1,10',  // 奖品类型，数组且每个元素为整型
         'type.*'                 => 'integer|length:1,10',  // 奖品类型，数组且每个元素为整型
@@ -39,10 +46,12 @@ class Lottery extends Validate
         'lottery_id_optional.gt'       => '活动ID必须大于0',
         'page.integer'              => '页码必须是整数',
         'page.egt'                  => '页码必须大于等于1',
-        'limit.integer'             => '每页数量必须是整数',
-        'limit.between'             => '每页数量必须在1-100之间',
+        'pageSize.integer'          => '每页数量必须是整数',
+        'pageSize.between'          => '每页数量必须在1-100之间',
         'status.integer'            => '状态必须是整数',
         'status.in'                 => '状态值不正确',
+        'record_status.integer'     => '状态必须是整数',
+        'record_status.in'          => '状态值不正确',
         'type.array'                => '奖品类型必须是数组格式',
         'type.*.integer'            => '奖品类型数组中的每个元素必须是整型',
         'type.*.length'             => '奖品类型数组中的每个元素长度必须在1-10之间',
@@ -78,18 +87,18 @@ class Lottery extends Validate
         'draw'                  => ['lottery_id'],
         // 获取用户抽奖机会（lottery_id必填）
         'getUserChances'        => ['lottery_id'],
-        // 获取用户抽奖记录（   可选，page和limit可选）
-        'getDrawRecords'        => ['lottery_id_optional', 'page', 'limit'],
-        // 获取用户中奖记录（page和limit可选）
-        'getWinRecords'         => ['page', 'limit'],
+        // 获取用户抽奖记录（   可选，page和pageSize可选）
+        'getDrawRecords'        => ['lottery_id_optional', 'page', 'pageSize', 'record_status'],
+        // 获取用户中奖记录（page和pageSize可选）
+        'getWinRecords'         => ['page', 'pageSize'],
         // 设置中奖记录收货地址（所有地址相关字段必填）
         'setWinRecordAddress'   => ['win_record_id', 'receiver_name', 'receiver_mobile', 'receiver_address'],
         // 设置详细收货地址（包含省市区）
         'setDetailAddress'      => ['win_record_id', 'receiver_name', 'receiver_mobile', 'province', 'city', 'district', 'detail_address'],
-        // 获取活动排行榜（lottery_id必填，page和limit可选）
-        'getRanking'            => ['lottery_id', 'page', 'limit'],
-        // 获取奖品列表（lottery_id可选，page、limit、type可选）
-        'getPrizes'             => ['lottery_id_optional', 'page', 'limit', 'type'],
+        // 获取活动排行榜（lottery_id必填，page和pageSize可选）
+        'getRanking'            => ['lottery_id', 'page', 'pageSize'],
+        // 获取奖品列表（lottery_id可选，page、pageSize、type可选）
+        'getPrizes'             => ['lottery_id_optional', 'page', 'pageSize', 'type'],
         // 获取订单完成后分发抽奖机会
         'getLotteryChanceByOrder' => ['order_id']
     ];

application/common/Enum/LotteryEnum.php

@@ -47,11 +47,16 @@ class LotteryEnum
       const DELIVER_TYPE_AUTO = 1;            // 自动发放
       const DELIVER_TYPE_MANUAL = 2;          // 手动发放
   
-      // ============ 奖品发放状态 ============
-      const DELIVER_STATUS_PENDING = 0;       // 待发放
-      const DELIVER_STATUS_SUCCESS = 1;       // 已发放
-      const DELIVER_STATUS_FAILED = 2;        // 发放失败
-      const DELIVER_STATUS_CANCELLED = 3;     // 已取消
+          // ============ 奖品发放状态 ============
+    const DELIVER_STATUS_PENDING = 0;       // 待发放
+    const DELIVER_STATUS_SUCCESS = 1;       // 已发放
+    const DELIVER_STATUS_FAILED = 2;        // 发放失败
+    const DELIVER_STATUS_CANCELLED = 3;     // 已取消
+
+    // ============ 抽奖状态 ============
+    const DRAW_STATUS_PARTICIPATED = 1;     // 已参与（等待开奖）
+    const DRAW_STATUS_WIN = 2;              // 已中奖
+    const DRAW_STATUS_NO_WIN = 3;           // 未中奖
   
       // ============ 参与条件类型 ============
       const CONDITION_TYPE_BUY_GOODS = 1;     // 购买指定商品
@@ -204,18 +209,38 @@ class LotteryEnum
           ];
       }
   
-      /**
-       * 获取奖品发放状态映射
-       */
-      public static function getDeliverStatusMap()
-      {
-          return [
-              self::DELIVER_STATUS_PENDING => '待发放',
-              self::DELIVER_STATUS_SUCCESS => '已发放',
-              self::DELIVER_STATUS_FAILED => '发放失败',
-              self::DELIVER_STATUS_CANCELLED => '已取消',
-          ];
-      }
+          /**
+     * 获取奖品发放状态映射
+     */
+    public static function getDeliverStatusMap()
+    {
+        return [
+            self::DELIVER_STATUS_PENDING => '待发放',
+            self::DELIVER_STATUS_SUCCESS => '已发放',
+            self::DELIVER_STATUS_FAILED => '发放失败',
+            self::DELIVER_STATUS_CANCELLED => '已取消',
+        ];
+    }
+
+    /**
+     * 获取抽奖状态映射
+     */
+    public static function getDrawStatusMap()
+    {
+        return [
+            self::DRAW_STATUS_PARTICIPATED => '已参与',
+            self::DRAW_STATUS_WIN => '已中奖',
+            self::DRAW_STATUS_NO_WIN => '未中奖',
+        ];
+    }
+    public static function getDrawStatusList()
+    {
+        return [
+            self::DRAW_STATUS_PARTICIPATED,
+            self::DRAW_STATUS_WIN,
+            self::DRAW_STATUS_NO_WIN,
+        ];
+    }
   
       /**
        * 获取参与条件类型映射
@@ -324,6 +349,15 @@ class LotteryEnum
         $map = self::getChanceGetTypeMap();
         return $map[$type] ?? '未知';
     }
+
+    /**
+     * 获取抽奖状态文本
+     */
+    public static function getDrawStatusText($status)
+    {
+        $map = self::getDrawStatusMap();
+        return $map[$status] ?? '未知';
+    }
   
       /**
        * 验证活动状态是否有效（包含所有状态）
@@ -386,4 +420,12 @@ class LotteryEnum
     {
         return array_key_exists($type, self::getChanceGetTypeMap());
     }
+
+    /**
+     * 验证抽奖状态是否有效
+     */
+    public static function isValidDrawStatus($status)
+    {
+        return array_key_exists($status, self::getDrawStatusMap());
+    }
 } 

application/common/Service/Lottery/LotteryRecordService.php

@@ -7,7 +7,7 @@ use app\common\model\lottery\LotteryWinRecord;
 use app\common\model\lottery\LotteryPrize;
 use app\common\Enum\LotteryEnum;
 use think\Exception;
-
+use app\common\model\lottery\LotteryActivity;
 /**
  * 抽奖记录服务类
  * 专门处理抽奖记录和中奖记录的业务逻辑
@@ -105,16 +105,20 @@ class LotteryRecordService
     /**
      * 获取用户抽奖记录列表
      */
-    public static function getUserDrawRecords($userId = 0, $activityId = null, $page = 1, $pageSize = 20)
+    public static function getUserDrawRecords($userId = 0, $activityId = null,$status = 0, $page = 1, $pageSize = 20)
     {
         $query = LotteryDrawRecord::where('user_id', $userId);
         
         if ($activityId) {
             $query->where('activity_id', $activityId);
         }
+        if ($status) {
+            $query->where('status', $status);
+        }
         
         // 1. 先分页查询抽奖记录
-        $records = $query->field('id,activity_id,prize_id,is_win,trigger_type,trigger_order_id,trigger_amount,draw_time')
+        $records = $query->field('id,activity_id,user_id,prize_id,is_win,trigger_type,trigger_order_id,trigger_amount,
+                        draw_time,status')
                         ->order('draw_time', 'desc')
                         ->paginate($pageSize, false, ['page' => $page]);
         
@@ -143,7 +147,7 @@ class LotteryRecordService
         // 3. 批量查询关联数据
         $activities = [];
         if (!empty($activityIds)) {
-            $activityList = \app\common\model\lottery\LotteryActivity::whereIn('id', $activityIds)
+            $activityList = LotteryActivity::whereIn('id', $activityIds)
                                 ->field('id,name,status,lottery_type')
                                 ->select();
             foreach ($activityList as $activity) {
@@ -153,7 +157,7 @@ class LotteryRecordService
         
         $prizes = [];
         if (!empty($prizeIds)) {
-            $prizeList = \app\common\model\lottery\LotteryPrize::whereIn('id', $prizeIds)
+            $prizeList = LotteryPrize::whereIn('id', $prizeIds)
                             ->field('id,name,image,activity_id,type')
                             ->select();
             foreach ($prizeList as $prize) {
@@ -163,7 +167,7 @@ class LotteryRecordService
         
         $winRecords = [];
         if (!empty($drawRecordIds)) {
-            $winRecordList = \app\common\model\lottery\LotteryWinRecord::whereIn('draw_record_id', $drawRecordIds)
+            $winRecordList = LotteryWinRecord::whereIn('draw_record_id', $drawRecordIds)
                                 ->field('id,draw_record_id,deliver_status,deliver_time,exchange_code,receiver_name,receiver_mobile,receiver_address,express_company,express_number,exchange_code')
                                 ->select();
             foreach ($winRecordList as $winRecord) {
@@ -210,26 +214,12 @@ class LotteryRecordService
             }
             
             // 添加触发类型文本
-            $record->trigger_type_text = static::getTriggerTypeText($record->trigger_type);
+            $record->trigger_type_text = LotteryEnum::getTriggerTypeMap($record->trigger_type);
         }
         
         return $records;
     }
     
-    /**
-     * 获取触发类型文本
-     */
-    private static function getTriggerTypeText($triggerType)
-    {
-        $map = [
-            1 => '购买商品',
-            2 => '订单消费', 
-            3 => '充值',
-            4 => '累计消费'
-        ];
-        
-        return $map[$triggerType] ?? '未知';
-    }
 
     /**
      * 获取活动抽奖记录列表

application/common/Service/Lottery/LotteryService.php

@@ -10,7 +10,8 @@ use app\common\Enum\ErrorCodeEnum;
 use think\Db;
 use think\Exception;
 use think\Cache;
-
+use app\common\model\lottery\LotteryDrawRecord;
+use app\common\model\User;
 /**
  * 抽奖服务类
  * 核心抽奖逻辑处理
@@ -98,18 +99,21 @@ class LotteryService
      */
     private static function handleLotteryByType($activity, $userId, $triggerType, $triggerOrderId, $triggerAmount)
     {
+        // 第一步：统一创建参与记录
+        $drawRecord = static::createParticipationRecord($activity, $userId, $triggerType, $triggerOrderId, $triggerAmount);
+        
         switch ($activity->lottery_type) {
             case LotteryEnum::LOTTERY_TYPE_INSTANT:
-                // 即抽即中：直接执行抽奖
-                return static::processDrawLottery($activity, $userId, $triggerType, $triggerOrderId, $triggerAmount);
+                // 即抽即中：立即执行抽奖并更新记录
+                return static::executeInstantDraw($drawRecord, $activity);
                 
             case LotteryEnum::LOTTERY_TYPE_TIME:
                 // 按时间开奖：记录参与，等待定时任务开奖
-                return static::recordParticipation($activity, $userId, $triggerType, $triggerOrderId, $triggerAmount);
+                return static::handleTimeLottery($drawRecord, $activity);
                 
             case LotteryEnum::LOTTERY_TYPE_PEOPLE:
                 // 按人数开奖：记录参与，检查是否达到开奖人数
-                return static::handlePeopleBasedLottery($activity, $userId, $triggerType, $triggerOrderId, $triggerAmount);
+                return static::handlePeopleLottery($drawRecord, $activity);
                 
             default:
                 throw new BusinessException('不支持的开奖方式', ErrorCodeEnum::LOTTERY_ACTIVITY_NOT_FOUND);
@@ -117,6 +121,175 @@ class LotteryService
     }
 
     /**
+     * 创建参与记录（统一入口）
+     */
+    private static function createParticipationRecord($activity, $userId, $triggerType, $triggerOrderId, $triggerAmount)
+    {
+        // 开启事务
+        Db::startTrans();
+        
+        try {
+            // 1. 消耗用户抽奖机会
+            $userChance = LotteryChanceService::getUserChance($activity->id, $userId);
+            if (!LotteryChanceService::useChance($userChance)) {
+                throw new BusinessException('抽奖机会使用失败');
+            }
+
+            // 2. 创建参与记录（状态为已参与）
+            $drawRecord = new LotteryDrawRecord([
+                'activity_id' => $activity->id,
+                'user_id' => $userId,
+                'prize_id' => 0, // 暂时没有奖品ID
+                'status' => LotteryEnum::DRAW_STATUS_PARTICIPATED, // 状态：已参与
+                'is_win' => 0, // 未开奖
+                'trigger_type' => $triggerType,
+                'trigger_order_id' => $triggerOrderId,
+                'trigger_amount' => $triggerAmount,
+                'win_info' => json_encode([]), // 暂时没有中奖信息
+                'draw_ip' => request()->ip(),
+                'draw_time' => time(),
+                'device_info' => request()->header('user-agent', ''),
+            ]);
+            
+            if (!$drawRecord->save()) {
+                throw new Exception('创建抽奖记录失败');
+            }
+
+            // 提交事务
+            Db::commit();
+            
+            return $drawRecord;
+
+        } catch (Exception $e) {
+            Db::rollback();
+            throw $e;
+        }
+    }
+
+    /**
+     * 执行即抽即中的抽奖逻辑
+     */
+    private static function executeInstantDraw($drawRecord, $activity)
+    {
+        try {
+            // 1. 获取可用奖品
+            $prizes = static::getAvailablePrizes($activity);
+        
+            if (empty($prizes)) {
+                throw new BusinessException('暂无可抽取的奖品');
+            }
+
+            // 2. 执行抽奖算法
+            $selectedPrize = static::executeLotteryAlgorithm($prizes);
+
+            // 3. 减少库存
+            if (!static::decreasePrizeStock($selectedPrize)) {
+                throw new BusinessException('奖品库存不足');
+            }
+
+            // 4. 更新抽奖记录
+            $isWin = $selectedPrize->type != LotteryEnum::PRIZE_TYPE_NO_PRIZE;
+            $winInfo = $isWin ? static::buildWinInfo($selectedPrize) : [];
+            
+            $drawRecord->prize_id = $selectedPrize->id;
+            $drawRecord->status = $isWin ? LotteryEnum::DRAW_STATUS_WIN : LotteryEnum::DRAW_STATUS_NO_WIN;
+            $drawRecord->is_win = $isWin ? 1 : 0;
+            $drawRecord->win_info = json_encode($winInfo);
+            $drawRecord->save();
+          
+            // 5. 如果中奖，创建中奖记录
+            $winRecord = null;
+            if ($isWin) {
+                $winRecord = new \app\common\model\lottery\LotteryWinRecord([
+                    'draw_record_id' => $drawRecord->id,
+                    'activity_id' => $activity->id,
+                    'user_id' => $drawRecord->user_id,
+                    'prize_id' => $selectedPrize->id,
+                    'prize_name' => $selectedPrize->name,
+                    'prize_type' => $selectedPrize->type,
+                    'prize_value' => json_encode(static::buildPrizeValue($selectedPrize)),
+                    'deliver_status' => LotteryEnum::DELIVER_STATUS_PENDING,
+                ]);
+                
+                if (!$winRecord->save()) {
+                    throw new Exception('创建中奖记录失败');
+                }
+
+                // 自动发放奖品
+                if ($selectedPrize->deliver_type == LotteryEnum::DELIVER_TYPE_AUTO) {
+                    static::autoDeliverPrize($winRecord, $selectedPrize);
+                }
+            }
+        
+            // 6. 更新活动统计
+            static::updateActivityStats($activity, $isWin);
+
+            // 7. 返回抽奖结果
+            return static::buildDrawResult($drawRecord, $selectedPrize, $winRecord);
+
+        } catch (Exception $e) {
+            // 如果发生错误，将状态改为未中奖
+            $drawRecord->status = LotteryEnum::DRAW_STATUS_NO_WIN;
+            $drawRecord->is_win = 0;
+            $drawRecord->save();
+            throw new BusinessException('抽奖失败');
+        }
+    }
+
+    /**
+     * 处理定时抽奖
+     */
+    private static function handleTimeLottery($drawRecord, $activity)
+    {
+        // 验证开奖时间
+        if (isset($activity->lottery_time) && $activity->lottery_time < time()) {
+            throw new BusinessException('活动开奖时间已过，无法参与');
+        }
+        
+        return [
+            'draw_id' => $drawRecord->id,
+            'is_win' => 0,
+            'status' => LotteryEnum::DRAW_STATUS_PARTICIPATED, // 等待开奖
+            'lottery_type' => $activity->lottery_type,
+            'lottery_time' => $activity->lottery_time ?? 0,
+            'message' => isset($activity->lottery_time) ? 
+                       '参与成功，等待' . date('Y-m-d H:i:s', $activity->lottery_time) . '开奖' : 
+                       '参与成功，等待开奖'
+        ];
+    }
+
+    /**
+     * 处理按人数抽奖
+     */
+    private static function handlePeopleLottery($drawRecord, $activity)
+    {
+        // 检查是否达到开奖人数
+        $participantCount = LotteryDrawRecord::where('activity_id', $activity->id)
+                                                                   ->where('status', LotteryEnum::DRAW_STATUS_PARTICIPATED)
+                                                                   ->count();
+        
+        $result = [
+            'draw_id' => $drawRecord->id,
+            'is_win' => 0,
+            'status' => 'waiting', // 等待开奖
+            'lottery_type' => $activity->lottery_type,
+            'current_participants' => $participantCount,
+            'required_participants' => $activity->lottery_people_num ?? 100
+        ];
+        
+        if ($participantCount >= ($activity->lottery_people_num ?? 100)) {
+            // 达到人数，触发开奖（这里可以异步处理）
+            // TODO: 触发按人数开奖的处理逻辑
+            $result['message'] = '参与成功，已达到开奖人数，正在开奖中...';
+        } else {
+            $remainingCount = ($activity->lottery_people_num ?? 100) - $participantCount;
+            $result['message'] = "参与成功，还需要{$remainingCount}人参与即可开奖";
+        }
+        
+        return $result;
+    }
+
+    /**
      * 处理抽奖核心逻辑
      */
     private static function processDrawLottery($activity, $userId, $triggerType, $triggerOrderId, $triggerAmount)
@@ -240,8 +413,137 @@ class LotteryService
 
         } catch (Exception $e) {
             Db::rollback();
-            throw $e;
+            throw new BusinessException('创建参与记录失败');
+        }
+    }
+
+    /**
+     * 定时任务：处理定时开奖活动
+     * 用于定时任务调用，批量处理到时间开奖的活动
+     */
+    public static function processScheduledLotteries()
+    {
+        // 获取所有到达开奖时间的活动
+        $activities = LotteryActivity::where('lottery_type', LotteryEnum::LOTTERY_TYPE_TIME)
+                        ->where('status', LotteryEnum::STATUS_ONGOING)
+                        ->where('lottery_time', '<=', time())
+                        ->select();
+        
+        $processedCount = 0;
+        
+        foreach ($activities as $activity) {
+            try {
+                $count = static::executeScheduledDraw($activity);
+                $processedCount += $count;
+                
+                // 更新活动状态为已结束
+                $activity->status = LotteryEnum::STATUS_ENDED;
+                $activity->save();
+                
+            } catch (Exception $e) {
+                trace("定时开奖失败 - 活动ID: {$activity->id}, 错误: " . $e->getMessage(), 'error');
+            }
+        }
+        
+        return $processedCount;
+    }
+    
+    /**
+     * 执行定时开奖
+     */
+    private static function executeScheduledDraw($activity)
+    {
+        // 获取所有参与记录
+        $participantRecords = LotteryDrawRecord::where('activity_id', $activity->id)
+                                ->where('status', LotteryEnum::DRAW_STATUS_PARTICIPATED)
+                                ->select();
+        
+        if (empty($participantRecords)) {
+            return 0;
+        }
+        
+        $processedCount = 0;
+        
+        foreach ($participantRecords as $drawRecord) {
+            try {
+                // 为每个参与记录执行抽奖
+                static::executeDrawForRecord($drawRecord, $activity);
+                $processedCount++;
+                
+            } catch (Exception $e) {
+                trace("用户开奖失败 - 记录ID: {$drawRecord->id}, 错误: " . $e->getMessage(), 'error');
+                
+                // 设置为未中奖
+                $drawRecord->status = LotteryEnum::DRAW_STATUS_NO_WIN;
+                $drawRecord->is_win = 0;
+                $drawRecord->save();
+            }
+        }
+        
+        return $processedCount;
+    }
+    
+    /**
+     * 为单个抽奖记录执行开奖
+     */
+    private static function executeDrawForRecord($drawRecord, $activity)
+    {
+        // 获取可用奖品
+        $prizes = static::getAvailablePrizes($activity);
+        
+        if (empty($prizes)) {
+            // 没有奖品，设置为未中奖
+            $drawRecord->status = LotteryEnum::DRAW_STATUS_NO_WIN;
+            $drawRecord->is_win = 0;
+            $drawRecord->save();
+            return;
+        }
+
+        // 执行抽奖算法
+        $selectedPrize = static::executeLotteryAlgorithm($prizes);
+
+        // 减少库存
+        if (!static::decreasePrizeStock($selectedPrize)) {
+            // 库存不足，设置为未中奖
+            $drawRecord->status = LotteryEnum::DRAW_STATUS_NO_WIN;
+            $drawRecord->is_win = 0;
+            $drawRecord->save();
+            return;
+        }
+
+        // 更新抽奖记录
+        $isWin = $selectedPrize->type != LotteryEnum::PRIZE_TYPE_NO_PRIZE;
+        $winInfo = $isWin ? static::buildWinInfo($selectedPrize) : [];
+        
+        $drawRecord->prize_id = $selectedPrize->id;
+        $drawRecord->status = $isWin ? LotteryEnum::DRAW_STATUS_WIN : LotteryEnum::DRAW_STATUS_NO_WIN;
+        $drawRecord->is_win = $isWin ? 1 : 0;
+        $drawRecord->win_info = json_encode($winInfo);
+        $drawRecord->save();
+      
+        // 如果中奖，创建中奖记录
+        if ($isWin) {
+            $winRecord = new \app\common\model\lottery\LotteryWinRecord([
+                'draw_record_id' => $drawRecord->id,
+                'activity_id' => $activity->id,
+                'user_id' => $drawRecord->user_id,
+                'prize_id' => $selectedPrize->id,
+                'prize_name' => $selectedPrize->name,
+                'prize_type' => $selectedPrize->type,
+                'prize_value' => json_encode(static::buildPrizeValue($selectedPrize)),
+                'deliver_status' => LotteryEnum::DELIVER_STATUS_PENDING,
+            ]);
+            
+            $winRecord->save();
+
+            // 自动发放奖品
+            if ($selectedPrize->deliver_type == LotteryEnum::DELIVER_TYPE_AUTO) {
+                static::autoDeliverPrize($winRecord, $selectedPrize);
+            }
         }
+    
+        // 更新活动统计
+        static::updateActivityStats($activity, $isWin);
     }
 
     /**
@@ -368,7 +670,7 @@ class LotteryService
             return true;
         }
         
-        $user = \app\common\model\User::find($userId);
+        $user = User::find($userId);
         return $user && in_array($user->level, (array)$limitValue);
     }
 
@@ -537,7 +839,7 @@ class LotteryService
     }
 
     /**
-     * 构建抽奖结果
+     * 构建即抽即中的抽奖结果
      */
     private static function buildDrawResult($drawRecord, $prize, $winRecord = null)
     {
@@ -549,7 +851,7 @@ class LotteryService
                 'name' => $prize->name,
                 'type' => $prize->type,
                 'type_text' => $prize->type_text,
-                'image' => $prize->image,
+                'image' => cdnurl($prize->image),
                 'win_prompt' => $prize->win_prompt
             ],
             'draw_time' => $drawRecord->draw_time

application/common/Service/lottery/LotteryRecordService.php

@@ -7,7 +7,7 @@ use app\common\model\lottery\LotteryWinRecord;
 use app\common\model\lottery\LotteryPrize;
 use app\common\Enum\LotteryEnum;
 use think\Exception;
-
+use app\common\model\lottery\LotteryActivity;
 /**
  * 抽奖记录服务类
  * 专门处理抽奖记录和中奖记录的业务逻辑
@@ -105,16 +105,20 @@ class LotteryRecordService
     /**
      * 获取用户抽奖记录列表
      */
-    public static function getUserDrawRecords($userId = 0, $activityId = null, $page = 1, $pageSize = 20)
+    public static function getUserDrawRecords($userId = 0, $activityId = null,$status = 0, $page = 1, $pageSize = 20)
     {
         $query = LotteryDrawRecord::where('user_id', $userId);
         
         if ($activityId) {
             $query->where('activity_id', $activityId);
         }
+        if ($status) {
+            $query->where('status', $status);
+        }
         
         // 1. 先分页查询抽奖记录
-        $records = $query->field('id,activity_id,prize_id,is_win,trigger_type,trigger_order_id,trigger_amount,draw_time')
+        $records = $query->field('id,activity_id,user_id,prize_id,is_win,trigger_type,trigger_order_id,trigger_amount,
+                        draw_time,status')
                         ->order('draw_time', 'desc')
                         ->paginate($pageSize, false, ['page' => $page]);
         
@@ -143,7 +147,7 @@ class LotteryRecordService
         // 3. 批量查询关联数据
         $activities = [];
         if (!empty($activityIds)) {
-            $activityList = \app\common\model\lottery\LotteryActivity::whereIn('id', $activityIds)
+            $activityList = LotteryActivity::whereIn('id', $activityIds)
                                 ->field('id,name,status,lottery_type')
                                 ->select();
             foreach ($activityList as $activity) {
@@ -153,7 +157,7 @@ class LotteryRecordService
         
         $prizes = [];
         if (!empty($prizeIds)) {
-            $prizeList = \app\common\model\lottery\LotteryPrize::whereIn('id', $prizeIds)
+            $prizeList = LotteryPrize::whereIn('id', $prizeIds)
                             ->field('id,name,image,activity_id,type')
                             ->select();
             foreach ($prizeList as $prize) {
@@ -163,7 +167,7 @@ class LotteryRecordService
         
         $winRecords = [];
         if (!empty($drawRecordIds)) {
-            $winRecordList = \app\common\model\lottery\LotteryWinRecord::whereIn('draw_record_id', $drawRecordIds)
+            $winRecordList = LotteryWinRecord::whereIn('draw_record_id', $drawRecordIds)
                                 ->field('id,draw_record_id,deliver_status,deliver_time,exchange_code,receiver_name,receiver_mobile,receiver_address,express_company,express_number,exchange_code')
                                 ->select();
             foreach ($winRecordList as $winRecord) {
@@ -210,26 +214,12 @@ class LotteryRecordService
             }
             
             // 添加触发类型文本
-            $record->trigger_type_text = static::getTriggerTypeText($record->trigger_type);
+            $record->trigger_type_text = LotteryEnum::getTriggerTypeMap($record->trigger_type);
         }
         
         return $records;
     }
     
-    /**
-     * 获取触发类型文本
-     */
-    private static function getTriggerTypeText($triggerType)
-    {
-        $map = [
-            1 => '购买商品',
-            2 => '订单消费', 
-            3 => '充值',
-            4 => '累计消费'
-        ];
-        
-        return $map[$triggerType] ?? '未知';
-    }
 
     /**
      * 获取活动抽奖记录列表

application/common/Service/lottery/LotteryService.php

@@ -10,7 +10,8 @@ use app\common\Enum\ErrorCodeEnum;
 use think\Db;
 use think\Exception;
 use think\Cache;
-
+use app\common\model\lottery\LotteryDrawRecord;
+use app\common\model\User;
 /**
  * 抽奖服务类
  * 核心抽奖逻辑处理
@@ -98,18 +99,21 @@ class LotteryService
      */
     private static function handleLotteryByType($activity, $userId, $triggerType, $triggerOrderId, $triggerAmount)
     {
+        // 第一步：统一创建参与记录
+        $drawRecord = static::createParticipationRecord($activity, $userId, $triggerType, $triggerOrderId, $triggerAmount);
+        
         switch ($activity->lottery_type) {
             case LotteryEnum::LOTTERY_TYPE_INSTANT:
-                // 即抽即中：直接执行抽奖
-                return static::processDrawLottery($activity, $userId, $triggerType, $triggerOrderId, $triggerAmount);
+                // 即抽即中：立即执行抽奖并更新记录
+                return static::executeInstantDraw($drawRecord, $activity);
                 
             case LotteryEnum::LOTTERY_TYPE_TIME:
                 // 按时间开奖：记录参与，等待定时任务开奖
-                return static::recordParticipation($activity, $userId, $triggerType, $triggerOrderId, $triggerAmount);
+                return static::handleTimeLottery($drawRecord, $activity);
                 
             case LotteryEnum::LOTTERY_TYPE_PEOPLE:
                 // 按人数开奖：记录参与，检查是否达到开奖人数
-                return static::handlePeopleBasedLottery($activity, $userId, $triggerType, $triggerOrderId, $triggerAmount);
+                return static::handlePeopleLottery($drawRecord, $activity);
                 
             default:
                 throw new BusinessException('不支持的开奖方式', ErrorCodeEnum::LOTTERY_ACTIVITY_NOT_FOUND);
@@ -117,6 +121,175 @@ class LotteryService
     }
 
     /**
+     * 创建参与记录（统一入口）
+     */
+    private static function createParticipationRecord($activity, $userId, $triggerType, $triggerOrderId, $triggerAmount)
+    {
+        // 开启事务
+        Db::startTrans();
+        
+        try {
+            // 1. 消耗用户抽奖机会
+            $userChance = LotteryChanceService::getUserChance($activity->id, $userId);
+            if (!LotteryChanceService::useChance($userChance)) {
+                throw new BusinessException('抽奖机会使用失败');
+            }
+
+            // 2. 创建参与记录（状态为已参与）
+            $drawRecord = new LotteryDrawRecord([
+                'activity_id' => $activity->id,
+                'user_id' => $userId,
+                'prize_id' => 0, // 暂时没有奖品ID
+                'status' => LotteryEnum::DRAW_STATUS_PARTICIPATED, // 状态：已参与
+                'is_win' => 0, // 未开奖
+                'trigger_type' => $triggerType,
+                'trigger_order_id' => $triggerOrderId,
+                'trigger_amount' => $triggerAmount,
+                'win_info' => json_encode([]), // 暂时没有中奖信息
+                'draw_ip' => request()->ip(),
+                'draw_time' => time(),
+                'device_info' => request()->header('user-agent', ''),
+            ]);
+            
+            if (!$drawRecord->save()) {
+                throw new Exception('创建抽奖记录失败');
+            }
+
+            // 提交事务
+            Db::commit();
+            
+            return $drawRecord;
+
+        } catch (Exception $e) {
+            Db::rollback();
+            throw $e;
+        }
+    }
+
+    /**
+     * 执行即抽即中的抽奖逻辑
+     */
+    private static function executeInstantDraw($drawRecord, $activity)
+    {
+        try {
+            // 1. 获取可用奖品
+            $prizes = static::getAvailablePrizes($activity);
+        
+            if (empty($prizes)) {
+                throw new BusinessException('暂无可抽取的奖品');
+            }
+
+            // 2. 执行抽奖算法
+            $selectedPrize = static::executeLotteryAlgorithm($prizes);
+
+            // 3. 减少库存
+            if (!static::decreasePrizeStock($selectedPrize)) {
+                throw new BusinessException('奖品库存不足');
+            }
+
+            // 4. 更新抽奖记录
+            $isWin = $selectedPrize->type != LotteryEnum::PRIZE_TYPE_NO_PRIZE;
+            $winInfo = $isWin ? static::buildWinInfo($selectedPrize) : [];
+            
+            $drawRecord->prize_id = $selectedPrize->id;
+            $drawRecord->status = $isWin ? LotteryEnum::DRAW_STATUS_WIN : LotteryEnum::DRAW_STATUS_NO_WIN;
+            $drawRecord->is_win = $isWin ? 1 : 0;
+            $drawRecord->win_info = json_encode($winInfo);
+            $drawRecord->save();
+          
+            // 5. 如果中奖，创建中奖记录
+            $winRecord = null;
+            if ($isWin) {
+                $winRecord = new \app\common\model\lottery\LotteryWinRecord([
+                    'draw_record_id' => $drawRecord->id,
+                    'activity_id' => $activity->id,
+                    'user_id' => $drawRecord->user_id,
+                    'prize_id' => $selectedPrize->id,
+                    'prize_name' => $selectedPrize->name,
+                    'prize_type' => $selectedPrize->type,
+                    'prize_value' => json_encode(static::buildPrizeValue($selectedPrize)),
+                    'deliver_status' => LotteryEnum::DELIVER_STATUS_PENDING,
+                ]);
+                
+                if (!$winRecord->save()) {
+                    throw new Exception('创建中奖记录失败');
+                }
+
+                // 自动发放奖品
+                if ($selectedPrize->deliver_type == LotteryEnum::DELIVER_TYPE_AUTO) {
+                    static::autoDeliverPrize($winRecord, $selectedPrize);
+                }
+            }
+        
+            // 6. 更新活动统计
+            static::updateActivityStats($activity, $isWin);
+
+            // 7. 返回抽奖结果
+            return static::buildDrawResult($drawRecord, $selectedPrize, $winRecord);
+
+        } catch (Exception $e) {
+            // 如果发生错误，将状态改为未中奖
+            $drawRecord->status = LotteryEnum::DRAW_STATUS_NO_WIN;
+            $drawRecord->is_win = 0;
+            $drawRecord->save();
+            throw new BusinessException('抽奖失败');
+        }
+    }
+
+    /**
+     * 处理定时抽奖
+     */
+    private static function handleTimeLottery($drawRecord, $activity)
+    {
+        // 验证开奖时间
+        if (isset($activity->lottery_time) && $activity->lottery_time < time()) {
+            throw new BusinessException('活动开奖时间已过，无法参与');
+        }
+        
+        return [
+            'draw_id' => $drawRecord->id,
+            'is_win' => 0,
+            'status' => LotteryEnum::DRAW_STATUS_PARTICIPATED, // 等待开奖
+            'lottery_type' => $activity->lottery_type,
+            'lottery_time' => $activity->lottery_time ?? 0,
+            'message' => isset($activity->lottery_time) ? 
+                       '参与成功，等待' . date('Y-m-d H:i:s', $activity->lottery_time) . '开奖' : 
+                       '参与成功，等待开奖'
+        ];
+    }
+
+    /**
+     * 处理按人数抽奖
+     */
+    private static function handlePeopleLottery($drawRecord, $activity)
+    {
+        // 检查是否达到开奖人数
+        $participantCount = LotteryDrawRecord::where('activity_id', $activity->id)
+                                                                   ->where('status', LotteryEnum::DRAW_STATUS_PARTICIPATED)
+                                                                   ->count();
+        
+        $result = [
+            'draw_id' => $drawRecord->id,
+            'is_win' => 0,
+            'status' => 'waiting', // 等待开奖
+            'lottery_type' => $activity->lottery_type,
+            'current_participants' => $participantCount,
+            'required_participants' => $activity->lottery_people_num ?? 100
+        ];
+        
+        if ($participantCount >= ($activity->lottery_people_num ?? 100)) {
+            // 达到人数，触发开奖（这里可以异步处理）
+            // TODO: 触发按人数开奖的处理逻辑
+            $result['message'] = '参与成功，已达到开奖人数，正在开奖中...';
+        } else {
+            $remainingCount = ($activity->lottery_people_num ?? 100) - $participantCount;
+            $result['message'] = "参与成功，还需要{$remainingCount}人参与即可开奖";
+        }
+        
+        return $result;
+    }
+
+    /**
      * 处理抽奖核心逻辑
      */
     private static function processDrawLottery($activity, $userId, $triggerType, $triggerOrderId, $triggerAmount)
@@ -240,8 +413,137 @@ class LotteryService
 
         } catch (Exception $e) {
             Db::rollback();
-            throw $e;
+            throw new BusinessException('创建参与记录失败');
+        }
+    }
+
+    /**
+     * 定时任务：处理定时开奖活动
+     * 用于定时任务调用，批量处理到时间开奖的活动
+     */
+    public static function processScheduledLotteries()
+    {
+        // 获取所有到达开奖时间的活动
+        $activities = LotteryActivity::where('lottery_type', LotteryEnum::LOTTERY_TYPE_TIME)
+                        ->where('status', LotteryEnum::STATUS_ONGOING)
+                        ->where('lottery_time', '<=', time())
+                        ->select();
+        
+        $processedCount = 0;
+        
+        foreach ($activities as $activity) {
+            try {
+                $count = static::executeScheduledDraw($activity);
+                $processedCount += $count;
+                
+                // 更新活动状态为已结束
+                $activity->status = LotteryEnum::STATUS_ENDED;
+                $activity->save();
+                
+            } catch (Exception $e) {
+                trace("定时开奖失败 - 活动ID: {$activity->id}, 错误: " . $e->getMessage(), 'error');
+            }
+        }
+        
+        return $processedCount;
+    }
+    
+    /**
+     * 执行定时开奖
+     */
+    private static function executeScheduledDraw($activity)
+    {
+        // 获取所有参与记录
+        $participantRecords = LotteryDrawRecord::where('activity_id', $activity->id)
+                                ->where('status', LotteryEnum::DRAW_STATUS_PARTICIPATED)
+                                ->select();
+        
+        if (empty($participantRecords)) {
+            return 0;
+        }
+        
+        $processedCount = 0;
+        
+        foreach ($participantRecords as $drawRecord) {
+            try {
+                // 为每个参与记录执行抽奖
+                static::executeDrawForRecord($drawRecord, $activity);
+                $processedCount++;
+                
+            } catch (Exception $e) {
+                trace("用户开奖失败 - 记录ID: {$drawRecord->id}, 错误: " . $e->getMessage(), 'error');
+                
+                // 设置为未中奖
+                $drawRecord->status = LotteryEnum::DRAW_STATUS_NO_WIN;
+                $drawRecord->is_win = 0;
+                $drawRecord->save();
+            }
+        }
+        
+        return $processedCount;
+    }
+    
+    /**
+     * 为单个抽奖记录执行开奖
+     */
+    private static function executeDrawForRecord($drawRecord, $activity)
+    {
+        // 获取可用奖品
+        $prizes = static::getAvailablePrizes($activity);
+        
+        if (empty($prizes)) {
+            // 没有奖品，设置为未中奖
+            $drawRecord->status = LotteryEnum::DRAW_STATUS_NO_WIN;
+            $drawRecord->is_win = 0;
+            $drawRecord->save();
+            return;
+        }
+
+        // 执行抽奖算法
+        $selectedPrize = static::executeLotteryAlgorithm($prizes);
+
+        // 减少库存
+        if (!static::decreasePrizeStock($selectedPrize)) {
+            // 库存不足，设置为未中奖
+            $drawRecord->status = LotteryEnum::DRAW_STATUS_NO_WIN;
+            $drawRecord->is_win = 0;
+            $drawRecord->save();
+            return;
+        }
+
+        // 更新抽奖记录
+        $isWin = $selectedPrize->type != LotteryEnum::PRIZE_TYPE_NO_PRIZE;
+        $winInfo = $isWin ? static::buildWinInfo($selectedPrize) : [];
+        
+        $drawRecord->prize_id = $selectedPrize->id;
+        $drawRecord->status = $isWin ? LotteryEnum::DRAW_STATUS_WIN : LotteryEnum::DRAW_STATUS_NO_WIN;
+        $drawRecord->is_win = $isWin ? 1 : 0;
+        $drawRecord->win_info = json_encode($winInfo);
+        $drawRecord->save();
+      
+        // 如果中奖，创建中奖记录
+        if ($isWin) {
+            $winRecord = new \app\common\model\lottery\LotteryWinRecord([
+                'draw_record_id' => $drawRecord->id,
+                'activity_id' => $activity->id,
+                'user_id' => $drawRecord->user_id,
+                'prize_id' => $selectedPrize->id,
+                'prize_name' => $selectedPrize->name,
+                'prize_type' => $selectedPrize->type,
+                'prize_value' => json_encode(static::buildPrizeValue($selectedPrize)),
+                'deliver_status' => LotteryEnum::DELIVER_STATUS_PENDING,
+            ]);
+            
+            $winRecord->save();
+
+            // 自动发放奖品
+            if ($selectedPrize->deliver_type == LotteryEnum::DELIVER_TYPE_AUTO) {
+                static::autoDeliverPrize($winRecord, $selectedPrize);
+            }
         }
+    
+        // 更新活动统计
+        static::updateActivityStats($activity, $isWin);
     }
 
     /**
@@ -368,7 +670,7 @@ class LotteryService
             return true;
         }
         
-        $user = \app\common\model\User::find($userId);
+        $user = User::find($userId);
         return $user && in_array($user->level, (array)$limitValue);
     }
 
@@ -537,7 +839,7 @@ class LotteryService
     }
 
     /**
-     * 构建抽奖结果
+     * 构建即抽即中的抽奖结果
      */
     private static function buildDrawResult($drawRecord, $prize, $winRecord = null)
     {
@@ -549,7 +851,7 @@ class LotteryService
                 'name' => $prize->name,
                 'type' => $prize->type,
                 'type_text' => $prize->type_text,
-                'image' => $prize->image,
+                'image' => cdnurl($prize->image),
                 'win_prompt' => $prize->win_prompt
             ],
             'draw_time' => $drawRecord->draw_time

application/common/model/lottery/LotteryDrawRecord.php

@@ -23,7 +23,8 @@ class LotteryDrawRecord extends Model
     // 追加属性
     protected $append = [
         'trigger_type_text',
-        'win_info_data'
+        'win_info_data',
+        'status_text'
     ];
 
     /**
@@ -90,4 +91,12 @@ class LotteryDrawRecord extends Model
     {
         return is_array($value) ? json_encode($value) : $value;
     }
+
+    /**
+     * 获取状态文本
+     */
+    public function getStatusTextAttr($value, $data)
+    {
+        return LotteryEnum::getDrawStatusText($data['status']);
+    }
 } 

docs/LotteryService文档说明.md

@@ -4,6 +4,13 @@
 
 `LotteryService` 是抽奖系统的核心服务类，负责处理抽奖的核心业务逻辑，包括抽奖执行、奖品管理、活动状态管理等功能。
 
+**最新优化**: 系统现已支持三种抽奖方式的统一处理：
+- **即抽即中** (LOTTERY_TYPE_INSTANT = 1): 用户抽奖后立即出结果
+- **定时开奖** (LOTTERY_TYPE_TIME = 2): 到指定时间统一开奖
+- **按人数开奖** (LOTTERY_TYPE_PEOPLE = 3): 达到指定人数后开奖
+
+所有抽奖方式都采用统一的"先记录参与，再更新结果"的流程，确保数据一致性和可追溯性。
+
 ## 类结构
 
 ```php
@@ -11,10 +18,27 @@ namespace app\common\Service\lottery;
 
 class LotteryService
 {
-    // 核心抽奖方法
+    // ============ 核心抽奖方法 ============
     public static function drawLottery($activityId, $userId, $triggerType, $triggerOrderId, $triggerAmount)
     
-    // 奖品管理方法
+    // ============ 三种抽奖方式处理方法 ============
+    // 统一处理入口
+    private static function handleLotteryByType($activity, $userId, $triggerType, $triggerOrderId, $triggerAmount)
+    private static function createParticipationRecord($activity, $userId, $triggerType, $triggerOrderId, $triggerAmount)
+    
+    // 即抽即中
+    private static function executeInstantDraw($drawRecord, $activity)
+    
+    // 定时开奖
+    private static function handleTimeLottery($drawRecord, $activity)
+    public static function processScheduledLotteries()  // 定时任务入口
+    private static function executeScheduledDraw($activity)
+    private static function executeDrawForRecord($drawRecord, $activity)
+    
+    // 按人数开奖
+    private static function handlePeopleLottery($drawRecord, $activity)
+    
+    // ============ 奖品管理方法 ============
     public static function hasPrizeStock(LotteryPrize $prize, $quantity)
     public static function decreasePrizeStock(LotteryPrize $prize, $quantity)
     public static function getAvailableExchangeCode(LotteryPrize $prize)
@@ -22,7 +46,7 @@ class LotteryService
     public static function getValidPrizes($activityId)
     public static function isPrizeUnlocked(LotteryPrize $prize, $currentPeopleCount)
     
-    // 活动状态管理方法
+    // ============ 活动状态管理方法 ============
     public static function isActivityRunning(LotteryActivity $activity)
     public static function isActivityEnded(LotteryActivity $activity)
     public static function isActivityNotStarted(LotteryActivity $activity)
@@ -36,8 +60,15 @@ class LotteryService
     public static function isValidActivityStatus(LotteryActivity $activity)
     public static function isValidLotteryType(LotteryActivity $activity)
     
-    // 用户机会管理方法
+    // ============ 用户机会管理方法 ============
     public static function getUserChances($activityId, $userId)
+    
+    // ============ 抽奖算法和辅助方法 ============
+    private static function executeLotteryAlgorithm($prizes)
+    private static function buildWinInfo($prize)
+    private static function buildPrizeValue($prize)
+    private static function updateActivityStats($activity, $isWin)
+    private static function buildDrawResult($drawRecord, $prize, $winRecord)
 }
 ```
 
@@ -70,15 +101,20 @@ try {
 
 **抽奖流程**:
 1. 验证活动有效性
-2. 验证抽奖时间
+2. 验证抽奖时间  
 3. 验证用户资格
 4. 检查用户抽奖机会
 5. 检查用户参与次数限制
 6. 防重复抽奖检查
 7. 使用Redis锁防止并发
-8. 执行抽奖核心逻辑
+8. **根据开奖方式分流处理**（新增）
 9. 返回抽奖结果
 
+**三种抽奖方式处理**:
+- **即抽即中**: 立即执行抽奖算法并返回结果
+- **定时开奖**: 创建参与记录，等待定时任务处理
+- **按人数开奖**: 检查人数，达标则触发开奖
+
 ### 2. processDrawLottery() - 处理抽奖核心逻辑
 
 **功能**: 私有方法，处理抽奖的核心业务逻辑。
@@ -112,6 +148,130 @@ $prizes = LotteryService::getValidPrizes($activityId);
 $selectedPrize = LotteryService::executeLotteryAlgorithm($prizes);
 ```
 
+## 三种抽奖方式详解
+
+### 1. 统一处理入口
+
+#### handleLotteryByType() - 根据开奖方式分流处理
+
+**功能**: 根据活动的开奖方式（lottery_type）分流到不同的处理逻辑。
+
+**流程**:
+1. 调用 `createParticipationRecord()` 创建参与记录
+2. 根据 `lottery_type` 分流处理：
+   - `LOTTERY_TYPE_INSTANT` → `executeInstantDraw()`
+   - `LOTTERY_TYPE_TIME` → `handleTimeLottery()`
+   - `LOTTERY_TYPE_PEOPLE` → `handlePeopleLottery()`
+
+#### createParticipationRecord() - 创建参与记录
+
+**功能**: 所有抽奖方式的统一入口，负责消耗用户机会并创建抽奖记录。
+
+**流程**:
+1. 开启数据库事务
+2. 消耗用户抽奖机会
+3. 创建抽奖记录（状态：`DRAW_STATUS_PARTICIPATED`）
+4. 提交事务
+5. 返回抽奖记录对象
+
+### 2. 即抽即中 (LOTTERY_TYPE_INSTANT = 1)
+
+#### executeInstantDraw() - 执行即抽即中抽奖
+
+**功能**: 立即执行抽奖并返回结果。
+
+**流程**:
+1. 获取可用奖品列表
+2. 执行抽奖算法选择奖品
+3. 减少奖品库存
+4. 更新抽奖记录状态和中奖信息
+5. 如果中奖，创建中奖记录
+6. 自动发放奖品（如果配置为自动发放）
+7. 更新活动统计
+8. 返回抽奖结果
+
+**使用场景**: 适用于需要立即反馈结果的抽奖活动。
+
+### 3. 定时开奖 (LOTTERY_TYPE_TIME = 2)
+
+#### handleTimeLottery() - 处理定时抽奖参与
+
+**功能**: 处理用户参与定时开奖活动。
+
+**流程**:
+1. 验证开奖时间是否已过期
+2. 返回等待开奖的状态信息
+
+#### processScheduledLotteries() - 定时任务处理入口
+
+**功能**: 公开方法，供定时任务调用，批量处理到期的定时开奖活动。
+
+**流程**:
+1. 查询所有到达开奖时间的活动
+2. 为每个活动调用 `executeScheduledDraw()`
+3. 更新活动状态为已结束
+4. 返回处理的记录数量
+
+#### executeScheduledDraw() - 执行定时开奖
+
+**功能**: 为指定活动执行定时开奖处理。
+
+**流程**:
+1. 获取所有参与记录（状态为 `DRAW_STATUS_PARTICIPATED`）
+2. 为每个参与记录调用 `executeDrawForRecord()`
+
+#### executeDrawForRecord() - 为单个记录执行开奖
+
+**功能**: 为单个抽奖记录执行开奖逻辑。
+
+**流程**:
+1. 获取可用奖品
+2. 执行抽奖算法
+3. 减少奖品库存
+4. 更新抽奖记录状态
+5. 创建中奖记录（如果中奖）
+6. 更新活动统计
+
+**定时任务配置示例**:
+```bash
+# 每分钟检查一次定时开奖活动
+* * * * * /usr/bin/php /path/to/project/think lottery:process-scheduled
+```
+
+### 4. 按人数开奖 (LOTTERY_TYPE_PEOPLE = 3)
+
+#### handlePeopleLottery() - 处理按人数抽奖
+
+**功能**: 处理按人数开奖的抽奖活动。
+
+**流程**:
+1. 查询当前参与人数
+2. 检查是否达到开奖人数 (`lottery_people_num`)
+3. 如果达到人数，触发开奖处理
+4. 如果未达到，返回等待状态和剩余人数信息
+
+**返回信息**:
+- 当前参与人数
+- 需要的参与人数
+- 是否达到开奖条件
+- 状态提示信息
+
+**使用场景**: 适用于需要聚集一定人数才开奖的活动，增加参与积极性。
+
+## 抽奖状态管理
+
+### 抽奖状态枚举
+```php
+const DRAW_STATUS_PARTICIPATED = 1;     // 已参与（等待开奖）
+const DRAW_STATUS_WIN = 2;              // 已中奖
+const DRAW_STATUS_NO_WIN = 3;           // 未中奖
+```
+
+### 状态流转
+1. **初始状态**: 创建记录时状态为 `DRAW_STATUS_PARTICIPATED`
+2. **开奖后**: 根据结果更新为 `DRAW_STATUS_WIN` 或 `DRAW_STATUS_NO_WIN`
+3. **异常处理**: 发生错误时自动设置为 `DRAW_STATUS_NO_WIN`
+
 ## 奖品管理方法
 
 ### 1. hasPrizeStock() - 检查奖品库存

docs/三种抽奖方式优化总结.md

@@ -0,0 +1,252 @@
+# 三种抽奖方式优化总结
+
+## 🎯 优化概述
+
+本次优化对消费抽奖营销活动系统进行了重大升级，实现了三种抽奖方式的统一处理流程，提升了系统的可维护性、扩展性和数据一致性。
+
+## 📊 优化前后对比
+
+### 优化前
+- 三种抽奖方式各自独立处理
+- 缺乏统一的状态管理
+- 抽奖记录创建时机不一致
+- 难以追溯和管理抽奖状态
+
+### 优化后
+- 统一的抽奖处理入口
+- 明确的状态流转管理
+- 所有抽奖方式先创建记录再处理
+- 完整的数据追溯链路
+
+## 🔧 核心优化内容
+
+### 1. 统一抽奖流程设计
+
+#### 新增统一处理方法
+- **`handleLotteryByType()`**: 根据开奖方式分流处理
+- **`createParticipationRecord()`**: 统一创建参与记录入口
+
+#### 流程标准化
+```
+用户抽奖 → 验证资格 → 消耗机会 → 创建记录 → 根据方式处理 → 更新状态 → 返回结果
+```
+
+### 2. 抽奖状态管理机制
+
+#### 新增状态枚举
+```php
+const DRAW_STATUS_PARTICIPATED = 1;     // 已参与（等待开奖）
+const DRAW_STATUS_WIN = 2;              // 已中奖
+const DRAW_STATUS_NO_WIN = 3;           // 未中奖
+```
+
+#### 状态流转规则
+- **初始状态**: 所有抽奖记录创建时状态为"已参与"
+- **结果状态**: 开奖后更新为"已中奖"或"未中奖"
+- **异常处理**: 发生错误时自动设置为"未中奖"
+
+### 3. 数据库表结构优化
+
+#### 抽奖记录表新增字段
+```sql
+-- shop_lottery_draw_record 表新增
+`status` tinyint(1) NOT NULL DEFAULT '1' COMMENT '抽奖状态: 1=已参与 2=已中奖 3=未中奖',
+`prize_id` int(11) NOT NULL DEFAULT '0' COMMENT '奖品ID，0表示未开奖',
+
+-- 新增索引
+KEY `idx_status` (`status`)
+```
+
+#### 机会记录表完善
+- 完善了 `shop_lottery_user_chance_record` 表结构
+- 优化了字段注释和索引设计
+
+## 🚀 三种抽奖方式详解
+
+### 1. 即抽即中 (LOTTERY_TYPE_INSTANT = 1)
+
+#### 新增方法
+- **`executeInstantDraw()`**: 执行即抽即中抽奖逻辑
+
+#### 处理流程
+```php
+createParticipationRecord()     // 创建参与记录
+↓
+executeInstantDraw()           // 立即执行抽奖
+├── 获取可用奖品
+├── 执行抽奖算法
+├── 减少奖品库存
+├── 更新记录状态
+├── 创建中奖记录(如果中奖)
+├── 自动发放奖品
+└── 更新活动统计
+↓
+返回抽奖结果
+```
+
+#### 优化特点
+- 实时处理，用户体验好
+- 完整的事务控制
+- 详细的错误处理
+
+### 2. 定时开奖 (LOTTERY_TYPE_TIME = 2)
+
+#### 新增方法
+- **`handleTimeLottery()`**: 处理定时抽奖参与
+- **`processScheduledLotteries()`**: 定时任务处理入口（公开方法）
+- **`executeScheduledDraw()`**: 执行定时开奖
+- **`executeDrawForRecord()`**: 为单个记录执行开奖
+
+#### 处理流程
+```php
+// 用户参与阶段
+createParticipationRecord()     // 创建参与记录
+↓
+handleTimeLottery()            // 处理定时抽奖
+├── 验证开奖时间
+└── 返回等待状态
+
+// 定时任务阶段
+processScheduledLotteries()     // 定时任务入口
+├── 查询到期活动
+├── executeScheduledDraw()     // 执行定时开奖
+│   └── executeDrawForRecord() // 为每个记录开奖
+└── 更新活动状态
+```
+
+#### 定时任务配置
+```bash
+# Linux Cron 配置
+* * * * * /usr/bin/php /path/to/project/think lottery:process-scheduled
+```
+
+#### 优化特点
+- 批量处理，减少系统压力
+- 公平开奖，所有用户同时处理
+- 支持大型活动的高并发场景
+
+### 3. 按人数开奖 (LOTTERY_TYPE_PEOPLE = 3)
+
+#### 新增方法
+- **`handlePeopleLottery()`**: 处理按人数抽奖
+
+#### 处理流程
+```php
+createParticipationRecord()     // 创建参与记录
+↓
+handlePeopleLottery()          // 处理按人数抽奖
+├── 查询当前参与人数
+├── 检查是否达到开奖人数
+├── 如果达标：触发批量开奖
+└── 如果不足：返回等待状态
+```
+
+#### 优化特点
+- 事件驱动，人数达标即开奖
+- 增加用户互动和传播效果
+- 实时反馈参与进度
+
+## 📈 技术优势
+
+### 1. 架构优势
+- **统一入口**: 所有抽奖方式使用相同的处理逻辑
+- **职责分离**: 每种方式有专门的处理方法
+- **易于扩展**: 新增抽奖方式只需添加对应的处理方法
+
+### 2. 数据一致性
+- **事务控制**: 关键操作使用数据库事务
+- **状态管理**: 明确的状态流转规则
+- **错误处理**: 完善的异常处理机制
+
+### 3. 性能优化
+- **批量处理**: 定时开奖和按人数开奖支持批量处理
+- **索引优化**: 新增状态字段索引提高查询效率
+- **并发控制**: 保留分布式锁机制（可选启用）
+
+### 4. 可维护性
+- **代码复用**: 通用逻辑统一处理
+- **清晰结构**: 方法职责明确，便于理解
+- **文档完善**: 详细的方法注释和文档
+
+## 🛠 实施步骤
+
+### 1. 数据库升级
+```sql
+-- 为抽奖记录表添加status字段
+ALTER TABLE shop_lottery_draw_record ADD `status` tinyint(1) NOT NULL DEFAULT '1' COMMENT '抽奖状态: 1=已参与 2=已中奖 3=未中奖' AFTER `prize_id`;
+
+-- 修改prize_id字段默认值
+ALTER TABLE shop_lottery_draw_record MODIFY `prize_id` int(11) NOT NULL DEFAULT '0' COMMENT '奖品ID，0表示未开奖';
+
+-- 添加状态字段索引
+ALTER TABLE shop_lottery_draw_record ADD KEY `idx_status` (`status`);
+```
+
+### 2. 代码部署
+- 部署更新后的 `LotteryService.php`
+- 部署更新后的 `LotteryEnum.php`
+- 确保所有相关依赖正常
+
+### 3. 定时任务配置
+```bash
+# 配置定时任务处理定时开奖
+* * * * * /usr/bin/php /path/to/project/think lottery:process-scheduled
+```
+
+### 4. 测试验证
+- 测试三种抽奖方式的正常流程
+- 验证状态流转的正确性
+- 确认定时任务的正常执行
+
+## 📋 兼容性说明
+
+### 向前兼容
+- 保留了原有的方法和接口
+- 现有的抽奖记录数据不受影响
+- 原有的API接口保持兼容
+
+### 数据迁移
+- 已有的抽奖记录会自动兼容新的状态字段
+- 旧记录的status字段默认为1（已参与）
+- 可根据is_win字段推断实际状态
+
+## 🔍 监控指标
+
+### 关键性能指标
+- 各种抽奖方式的响应时间
+- 定时任务的执行效率
+- 状态流转的准确性
+- 数据一致性检查
+
+### 业务指标
+- 三种抽奖方式的使用分布
+- 用户参与度和中奖率
+- 活动效果对比分析
+
+## 🎉 预期效果
+
+### 技术效果
+1. **提升可维护性**: 统一的处理流程易于维护和扩展
+2. **增强数据一致性**: 明确的状态管理减少数据异常
+3. **改善用户体验**: 三种抽奖方式满足不同场景需求
+4. **优化系统性能**: 批量处理和索引优化提升性能
+
+### 业务效果
+1. **活动灵活性**: 支持多种抽奖模式适应不同营销策略
+2. **用户参与度**: 按人数开奖增加用户互动
+3. **运营效率**: 定时开奖适合大型促销活动
+4. **数据分析**: 完整的状态记录便于效果分析
+
+## 📚 相关文档
+
+- [消费抽奖系统架构流程图](./消费抽奖系统架构流程图.md)
+- [LotteryService文档说明](./LotteryService文档说明.md)
+- [消费抽奖营销活动_使用说明](./消费抽奖营销活动_使用说明.md)
+- [消费抽奖营销活动_数据库建表脚本](./消费抽奖营销活动_数据库建表脚本.sql)
+
+---
+
+**优化完成时间**: 2024年12月
+**涉及文件**: LotteryService.php, LotteryEnum.php, 相关文档
+**测试状态**: 待测试
+**上线状态**: 待部署 

docs/文档更新清单.md

@@ -0,0 +1,170 @@
+# 消费抽奖系统文档更新清单
+
+## 📅 更新时间
+2024年12月 - 三种抽奖方式优化版本
+
+## 🎯 更新概述
+本次更新对消费抽奖营销活动系统的三种抽奖方式进行了统一优化，涉及代码重构、文档更新和流程图制作。
+
+## 📝 新增文档
+
+### 1. 消费抽奖系统架构流程图.md ⭐ 新增
+- **内容**: 完整的三种抽奖方式流程图
+- **包含**: 
+  - 主要抽奖流程图
+  - 抽奖状态流转图
+  - 三种方式的详细时序图
+  - 数据库表结构优化说明
+  - 核心方法说明表格
+  - 定时任务配置示例
+
+### 2. 三种抽奖方式优化总结.md ⭐ 新增
+- **内容**: 本次优化的完整总结报告
+- **包含**:
+  - 优化前后对比
+  - 核心优化内容详解
+  - 三种抽奖方式技术实现
+  - 技术优势和业务效果
+  - 实施步骤和兼容性说明
+  - 监控指标和预期效果
+
+### 3. 文档更新清单.md ⭐ 新增
+- **内容**: 本次更新涉及的所有文档变更记录
+- **用途**: 帮助开发者快速了解文档变更情况
+
+## 📖 更新文档
+
+### 1. LotteryService文档说明.md ⭐ 重大更新
+**更新内容**:
+- 新增三种抽奖方式处理的详细说明
+- 更新类结构，增加新方法分类
+- 新增统一处理入口说明
+- 新增抽奖状态管理章节
+- 更新核心方法流程说明
+
+**主要新增章节**:
+- 三种抽奖方式详解
+- 统一处理入口
+- 抽奖状态管理
+- 定时任务配置
+
+### 2. 消费抽奖营销活动_使用说明.md ⭐ 功能更新
+**更新内容**:
+- 文档概述增加最新优化说明
+- 更新系统架构中的开奖机制描述
+- 新增抽奖状态管理说明
+- 更新数据表关系图
+- 优化用户参与流程
+- 详细更新开奖模式配置章节
+
+**主要更新章节**:
+- 抽奖状态管理（新增）
+- 用户参与流程（重写）
+- 开奖模式配置（详细化）
+
+### 3. 消费抽奖营销活动_数据库建表脚本.sql ⭐ 结构更新
+**更新内容**:
+- 抽奖记录表新增status字段
+- 修改prize_id字段默认值为0
+- 新增status字段索引
+- 更新表注释说明
+
+**具体变更**:
+```sql
+-- 新增字段
+`status` tinyint(1) NOT NULL DEFAULT '1' COMMENT '抽奖状态: 1=已参与 2=已中奖 3=未中奖'
+
+-- 修改字段
+`prize_id` int(11) NOT NULL DEFAULT '0' COMMENT '奖品ID，0表示未开奖'
+
+-- 新增索引
+KEY `idx_status` (`status`)
+```
+
+## 🔧 相关代码文件
+
+### 1. application/common/Service/Lottery/LotteryService.php ⭐ 核心重构
+**新增方法**:
+- `handleLotteryByType()` - 抽奖方式分流处理
+- `createParticipationRecord()` - 统一创建参与记录
+- `executeInstantDraw()` - 即抽即中处理
+- `handleTimeLottery()` - 定时抽奖处理
+- `handlePeopleLottery()` - 按人数抽奖处理
+- `processScheduledLotteries()` - 定时任务入口（公开）
+- `executeScheduledDraw()` - 执行定时开奖
+- `executeDrawForRecord()` - 单记录开奖处理
+
+### 2. application/common/Enum/LotteryEnum.php ⭐ 枚举扩展
+**新增常量**:
+```php
+// 抽奖状态
+const DRAW_STATUS_PARTICIPATED = 1;     // 已参与
+const DRAW_STATUS_WIN = 2;              // 已中奖
+const DRAW_STATUS_NO_WIN = 3;           // 未中奖
+```
+
+**新增方法**:
+- `getDrawStatusMap()` - 获取抽奖状态映射
+- `getDrawStatusText()` - 获取抽奖状态文本
+- `isValidDrawStatus()` - 验证抽奖状态
+
+## 📊 文档更新统计
+
+| 类型 | 数量 | 文件列表 |
+|------|------|----------|
+| 新增文档 | 3 | 消费抽奖系统架构流程图.md<br/>三种抽奖方式优化总结.md<br/>文档更新清单.md |
+| 重大更新 | 3 | LotteryService文档说明.md<br/>消费抽奖营销活动_使用说明.md<br/>消费抽奖营销活动_数据库建表脚本.sql |
+| 代码文件 | 2 | LotteryService.php<br/>LotteryEnum.php |
+
+## 🎨 流程图资源
+
+### Mermaid 图表类型
+- **主流程图**: 展示完整的抽奖处理流程
+- **状态流转图**: 展示抽奖状态的转换关系
+- **时序图**: 展示三种抽奖方式的详细交互流程
+
+### 图表特点
+- 使用颜色区分不同的处理阶段
+- 清晰的流程节点和判断条件
+- 完整的错误处理路径
+- 易于理解的视觉呈现
+
+## ✅ 验证清单
+
+### 文档完整性检查
+- [x] 所有新增文档已创建
+- [x] 所有更新文档已修改
+- [x] 流程图已包含在相应文档中
+- [x] 代码示例已更新
+- [x] 配置说明已完善
+
+### 技术文档检查
+- [x] 方法签名和参数说明准确
+- [x] 流程图与代码实现一致
+- [x] 数据库脚本与表结构匹配
+- [x] 配置示例可直接使用
+
+### 业务文档检查
+- [x] 三种抽奖方式说明清晰
+- [x] 使用场景描述准确
+- [x] 优化效果说明完整
+- [x] 实施步骤详细可操作
+
+## 🔄 后续维护
+
+### 文档维护建议
+1. **定期更新**: 随着功能迭代及时更新相关文档
+2. **版本管理**: 建议为重大更新打标签或版本号
+3. **反馈收集**: 收集使用者反馈，持续改进文档质量
+4. **示例更新**: 根据实际使用情况更新代码示例
+
+### 监控要点
+1. **文档使用率**: 统计各文档的访问和使用情况
+2. **问题反馈**: 收集文档使用中遇到的问题
+3. **准确性验证**: 定期验证文档与代码的一致性
+
+---
+
+**更新负责人**: AI Assistant  
+**审核状态**: 待审核  
+**生效时间**: 待确认 

docs/消费抽奖系统架构流程图.md

@@ -0,0 +1,273 @@
+# 消费抽奖系统架构流程图
+
+## 概述
+
+本文档展示了消费抽奖系统优化后的三种抽奖方式处理流程。系统支持即抽即中、定时开奖、按人数开奖三种模式，通过统一的入口进行处理。
+
+## 主要抽奖流程图
+
+```mermaid
+graph TD
+    A[用户触发抽奖] --> B[验证用户资格]
+    B --> C[消耗抽奖机会]
+    C --> D[创建抽奖记录<br/>状态: 已参与]
+    
+    D --> E{开奖方式}
+    
+    E -->|即抽即中| F[立即执行抽奖]
+    F --> G[获取可用奖品]
+    G --> H[执行抽奖算法]
+    H --> I[减少奖品库存]
+    I --> J[更新抽奖记录<br/>状态: 已中奖/未中奖]
+    J --> K{是否中奖}
+    K -->|是| L[创建中奖记录]
+    K -->|否| M[返回未中奖结果]
+    L --> N[自动发放奖品]
+    N --> O[更新活动统计]
+    O --> P[返回中奖结果]
+    
+    E -->|定时开奖| Q[等待开奖时间]
+    Q --> R[返回等待状态]
+    R --> S[定时任务处理]
+    S --> T[批量处理参与记录]
+    T --> U[为每个记录执行抽奖]
+    U --> V[更新记录状态]
+    
+    E -->|按人数开奖| W[检查参与人数]
+    W --> X{达到开奖人数?}
+    X -->|是| Y[触发开奖处理]
+    X -->|否| Z[返回等待状态]
+    Y --> AA[批量处理参与记录]
+    
+    style D fill:#e1f5fe
+    style J fill:#fff3e0
+    style L fill:#e8f5e8
+    style S fill:#f3e5f5
+    style AA fill:#fff8e1
+```
+
+## 抽奖状态流转图
+
+```mermaid
+stateDiagram-v2
+    [*] --> 已参与: 用户参与抽奖
+    已参与 --> 已中奖: 抽奖结果为中奖
+    已参与 --> 未中奖: 抽奖结果为未中奖
+    已中奖 --> [*]: 流程结束
+    未中奖 --> [*]: 流程结束
+    
+    note right of 已参与
+        状态码: 1
+        等待开奖或立即开奖
+    end note
+    
+    note right of 已中奖
+        状态码: 2
+        创建中奖记录
+    end note
+    
+    note right of 未中奖
+        状态码: 3
+        记录未中奖
+    end note
+```
+
+## 三种抽奖方式详细流程
+
+### 1. 即抽即中 (LOTTERY_TYPE_INSTANT = 1)
+
+```mermaid
+sequenceDiagram
+    participant User as 用户
+    participant API as API接口
+    participant Service as LotteryService
+    participant DB as 数据库
+    
+    User->>API: 发起抽奖请求
+    API->>Service: drawLottery()
+    Service->>Service: 验证用户资格
+    Service->>Service: 消耗抽奖机会
+    Service->>DB: 创建抽奖记录(状态:已参与)
+    Service->>Service: executeInstantDraw()
+    Service->>Service: 获取可用奖品
+    Service->>Service: 执行抽奖算法
+    Service->>Service: 减少奖品库存
+    Service->>DB: 更新抽奖记录(状态:已中奖/未中奖)
+    alt 中奖
+        Service->>DB: 创建中奖记录
+        Service->>Service: 自动发放奖品
+    end
+    Service->>Service: 更新活动统计
+    Service->>API: 返回抽奖结果
+    API->>User: 显示抽奖结果
+```
+
+### 2. 定时开奖 (LOTTERY_TYPE_TIME = 2)
+
+```mermaid
+sequenceDiagram
+    participant User as 用户
+    participant API as API接口
+    participant Service as LotteryService
+    participant Cron as 定时任务
+    participant DB as 数据库
+    
+    User->>API: 发起抽奖请求
+    API->>Service: drawLottery()
+    Service->>Service: 验证用户资格
+    Service->>Service: 消耗抽奖机会
+    Service->>DB: 创建抽奖记录(状态:已参与)
+    Service->>Service: handleTimeLottery()
+    Service->>API: 返回等待状态
+    API->>User: 显示等待开奖
+    
+    Note over Cron: 到达开奖时间
+    Cron->>Service: processScheduledLotteries()
+    Service->>DB: 查询待开奖记录
+    loop 处理每个参与记录
+        Service->>Service: executeDrawForRecord()
+        Service->>Service: 执行抽奖算法
+        Service->>DB: 更新记录状态
+        alt 中奖
+            Service->>DB: 创建中奖记录
+        end
+    end
+    Service->>DB: 更新活动状态为已结束
+```
+
+### 3. 按人数开奖 (LOTTERY_TYPE_PEOPLE = 3)
+
+```mermaid
+sequenceDiagram
+    participant User as 用户
+    participant API as API接口
+    participant Service as LotteryService
+    participant DB as 数据库
+    
+    User->>API: 发起抽奖请求
+    API->>Service: drawLottery()
+    Service->>Service: 验证用户资格
+    Service->>Service: 消耗抽奖机会
+    Service->>DB: 创建抽奖记录(状态:已参与)
+    Service->>Service: handlePeopleLottery()
+    Service->>DB: 查询当前参与人数
+    alt 人数未达标
+        Service->>API: 返回等待状态
+        API->>User: 显示还需X人参与
+    else 人数达标
+        Service->>Service: 触发批量开奖
+        loop 处理所有参与记录
+            Service->>Service: executeDrawForRecord()
+            Service->>DB: 更新记录状态
+        end
+        Service->>API: 返回开奖中状态
+        API->>User: 显示正在开奖
+    end
+```
+
+## 数据库表结构优化
+
+### 抽奖记录表 (shop_lottery_draw_record) 新增字段
+
+| 字段名 | 类型 | 默认值 | 说明 |
+|--------|------|--------|------|
+| status | tinyint(1) | 1 | 抽奖状态: 1=已参与 2=已中奖 3=未中奖 |
+| prize_id | int(11) | 0 | 奖品ID，0表示未开奖 |
+
+### 抽奖状态枚举
+
+```php
+// 抽奖状态常量
+const DRAW_STATUS_PARTICIPATED = 1;     // 已参与（等待开奖）
+const DRAW_STATUS_WIN = 2;              // 已中奖
+const DRAW_STATUS_NO_WIN = 3;           // 未中奖
+```
+
+## 核心方法说明
+
+### 统一处理方法
+
+| 方法名 | 说明 | 公开性 |
+|--------|------|--------|
+| `handleLotteryByType()` | 根据开奖方式分流处理 | private |
+| `createParticipationRecord()` | 创建参与记录统一入口 | private |
+
+### 即抽即中方法
+
+| 方法名 | 说明 | 公开性 |
+|--------|------|--------|
+| `executeInstantDraw()` | 执行即抽即中抽奖 | private |
+
+### 定时开奖方法
+
+| 方法名 | 说明 | 公开性 |
+|--------|------|--------|
+| `handleTimeLottery()` | 处理定时抽奖参与 | private |
+| `processScheduledLotteries()` | 定时任务处理入口 | public |
+| `executeScheduledDraw()` | 执行定时开奖 | private |
+| `executeDrawForRecord()` | 为单个记录执行开奖 | private |
+
+### 按人数开奖方法
+
+| 方法名 | 说明 | 公开性 |
+|--------|------|--------|
+| `handlePeopleLottery()` | 处理按人数抽奖 | private |
+
+## 定时任务配置
+
+### Linux Cron 配置示例
+
+```bash
+# 每分钟检查一次定时开奖活动
+* * * * * /usr/bin/php /path/to/project/think lottery:process-scheduled
+```
+
+### ThinkPHP 命令行示例
+
+```php
+<?php
+// application/console/command/ProcessScheduledLottery.php
+
+namespace app\console\command;
+
+use think\console\Command;
+use think\console\Input;
+use think\console\Output;
+use app\common\Service\Lottery\LotteryService;
+
+class ProcessScheduledLottery extends Command
+{
+    protected function configure()
+    {
+        $this->setName('lottery:process-scheduled')
+             ->setDescription('处理定时开奖活动');
+    }
+
+    protected function execute(Input $input, Output $output)
+    {
+        try {
+            $count = LotteryService::processScheduledLotteries();
+            $output->writeln("处理完成，共处理 {$count} 条记录");
+        } catch (\Exception $e) {
+            $output->writeln("处理失败: " . $e->getMessage());
+        }
+    }
+}
+```
+
+## 优化特点
+
+1. **统一入口**: 所有抽奖方式都通过统一的流程处理
+2. **状态管理**: 明确的抽奖状态流转
+3. **并发安全**: 使用事务和锁机制保证数据一致性
+4. **可扩展性**: 便于增加新的开奖方式
+5. **容错性**: 完善的异常处理机制
+6. **性能优化**: 批量处理减少数据库压力
+
+## 注意事项
+
+1. **定时任务**: 需要配置定时任务处理定时开奖
+2. **人数开奖**: 达到人数后可以异步处理避免阻塞
+3. **库存控制**: 抽奖前必须检查奖品库存
+4. **事务处理**: 关键操作使用数据库事务
+5. **状态一致性**: 确保抽奖记录状态的正确更新 

docs/消费抽奖营销活动_使用说明.md

@@ -9,13 +9,19 @@
 3. **表字段说明** - 每个字段的详细说明和使用方法
 4. **数据库脚本** - 可直接执行的建表SQL脚本
 
+**最新优化**: 
+- 三种抽奖方式统一处理流程
+- 新增抽奖状态管理机制
+- 支持定时任务批量开奖
+- 完善的并发控制和数据一致性保证
+
 ## 2. 系统架构
 
 ### 2.1 核心功能模块
 - **活动管理**: 创建和管理抽奖活动
 - **奖品配置**: 设置多种类型的奖品
 - **参与条件**: 灵活的消费触发条件
-- **开奖机制**: 三种开奖模式（即抽即中、按时间、按人数）
+- **开奖机制**: 三种开奖模式（即抽即中、按时间、按人数），统一流程处理
 - **用户管理**: 精准的用户群体控制
 - **统计分析**: 完整的数据统计和报表
 
@@ -24,12 +30,23 @@
 shop_lottery_activity (活动主表)
 ├── shop_lottery_prize (奖品表)
 ├── shop_lottery_condition (条件表)
-├── shop_lottery_draw_record (抽奖记录表)
+├── shop_lottery_draw_record (抽奖记录表) ⭐ 新增status字段
 ├── shop_lottery_win_record (中奖记录表)
 ├── shop_lottery_user_chance (用户机会表)
+├── shop_lottery_user_chance_record (机会获取记录表) ⭐ 新增
 └── shop_lottery_statistics (统计表)
 ```
 
+### 2.3 抽奖状态管理 ⭐ 新增
+```
+抽奖记录状态流转:
+已参与(1) → 已中奖(2) | 未中奖(3)
+
+- 已参与: 用户完成抽奖，等待开奖结果
+- 已中奖: 开奖后确定中奖，创建中奖记录
+- 未中奖: 开奖后确定未中奖
+```
+
 ## 3. 快速开始
 
 ### 3.1 环境要求
@@ -77,23 +94,29 @@ shop_lottery_activity (活动主表)
    └── 状态设为"进行中"
 ```
 
-### 4.2 用户参与流程
+### 4.2 用户参与流程 ⭐ 已优化
 ```
 1. 触发条件检查
    ├── 用户购买商品/充值
    ├── 检查是否满足参与条件
    └── 生成抽奖机会
 
-2. 执行抽奖
+2. 统一抽奖处理 ⭐ 新增
    ├── 验证用户资格
-   ├── 检查剩余次数
-   ├── 执行抽奖算法
-   └── 返回抽奖结果
-
-3. 奖品发放
-   ├── 记录中奖信息
-   ├── 根据奖品类型发放
-   └── 更新相关统计
+   ├── 消耗抽奖机会
+   ├── 创建抽奖记录（状态：已参与）
+   └── 根据开奖方式分流处理
+
+3. 开奖方式处理
+   ├── 即抽即中：立即开奖返回结果
+   ├── 定时开奖：等待定时任务处理
+   └── 按人数开奖：检查人数触发开奖
+
+4. 结果处理
+   ├── 更新抽奖记录状态
+   ├── 创建中奖记录（如果中奖）
+   ├── 自动发放奖品
+   └── 更新活动统计
 ```
 
 ## 5. 配置说明
@@ -121,19 +144,59 @@ shop_lottery_activity (活动主表)
 - 关联商城商品
 - 支持指定SKU
 
-### 5.2 开奖模式配置
+### 5.2 开奖模式配置 ⭐ 已优化
 
 #### 即抽即中 (lottery_type=1)
-- 用户抽奖后立即出结果
-- 适合日常营销活动
+- **处理方式**: 用户抽奖后立即执行抽奖算法并返回结果
+- **适用场景**: 日常营销活动、节日活动
+- **用户体验**: 即时反馈，参与感强
+- **技术特点**: 实时处理，对系统性能要求较高
+
+```php
+// 处理流程
+createParticipationRecord() → executeInstantDraw() → 返回结果
+```
 
 #### 按时间开奖 (lottery_type=2)
-- 设置统一开奖时间
-- 支持按人数解锁奖品功能
+- **处理方式**: 用户参与后等待，到指定时间统一开奖
+- **配置字段**: `lottery_time` - 开奖时间戳
+- **适用场景**: 大型促销活动、重要节日营销
+- **用户体验**: 营造期待感，适合大奖活动
+- **技术特点**: 定时任务批量处理，减少系统压力
+
+```php
+// 处理流程
+createParticipationRecord() → handleTimeLottery() → 等待定时任务
+定时任务: processScheduledLotteries() → 批量开奖
+```
+
+**定时任务配置**:
+```bash
+# Linux Cron 每分钟检查一次
+* * * * * /usr/bin/php /path/to/project/think lottery:process-scheduled
+```
 
 #### 按人数开奖 (lottery_type=3)
-- 达到指定人数后开奖
-- 适合拼团类活动
+- **处理方式**: 达到指定参与人数后自动触发开奖
+- **配置字段**: `lottery_people_num` - 开奖所需人数
+- **适用场景**: 拼团活动、社交营销
+- **用户体验**: 增加互动性和传播效果
+- **技术特点**: 事件驱动，人数达标即触发
+
+```php
+// 处理流程
+createParticipationRecord() → handlePeopleLottery() → 检查人数
+人数达标: 触发批量开奖 | 人数不足: 返回等待状态
+```
+
+#### 开奖状态管理
+所有开奖方式都使用统一的状态管理：
+
+| 状态码 | 状态名称 | 说明 |
+|--------|----------|------|
+| 1 | 已参与 | 用户完成抽奖，等待开奖结果 |
+| 2 | 已中奖 | 开奖后确定中奖，已创建中奖记录 |
+| 3 | 未中奖 | 开奖后确定未中奖 |
 
 ### 5.3 参与条件配置
 

docs/消费抽奖营销活动_数据库建表脚本.sql

@@ -141,7 +141,8 @@ CREATE TABLE `shop_lottery_draw_record` (
   `id` int(11) NOT NULL AUTO_INCREMENT COMMENT '记录ID',
   `activity_id` int(11) NOT NULL COMMENT '活动ID',
   `user_id` int(11) NOT NULL COMMENT '用户ID',
-  `prize_id` int(11) NOT NULL COMMENT '奖品ID',
+  `prize_id` int(11) NOT NULL DEFAULT '0' COMMENT '奖品ID，0表示未开奖',
+  `status` tinyint(1) NOT NULL DEFAULT '1' COMMENT '抽奖状态: 1=已参与 2=已中奖 3=未中奖',
   `is_win` tinyint(1) NOT NULL DEFAULT '0' COMMENT '是否中奖: 0=未中奖 1=中奖',
   `win_info` text COMMENT '中奖信息(JSON格式)',
   `trigger_type` tinyint(1) NOT NULL COMMENT '触发类型: 1=购买商品 2=订单消费 3=充值 4=累计消费',
@@ -156,6 +157,7 @@ CREATE TABLE `shop_lottery_draw_record` (
   UNIQUE KEY `uniq_activity_user_order` (`activity_id`,`user_id`,`trigger_order_id`),
   KEY `idx_activity_id` (`activity_id`),
   KEY `idx_user_id` (`user_id`),
+  KEY `idx_status` (`status`),
   KEY `idx_is_win` (`is_win`),
   KEY `idx_draw_time` (`draw_time`),
   KEY `idx_createtime` (`createtime`)