<?php

namespace App\Console\Commands;

use App\Models\Coupon;
use App\Models\CouponSendTask;
use App\Models\CouponTaskLog;
use App\Models\UserCoupon;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\DB;
use Throwable;

class AdminSendCoupon extends Command
{
    /**
     * 单次最大条数
     *
     * @var integer
     */
    protected $limit = 100;
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'admin-work:send-coupon';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = '后台执行优惠券发放任务';

    /**
     * Create a new command instance.
     *
     * @return void
     */
    public function __construct()
    {
        parent::__construct();
    }

    /**
     * Execute the console command.
     *
     * @return int
     */
    public function handle()
    {
        //获取需要执行的任务数据包
        $logs = CouponTaskLog::where('status', '0')->where('num', '>', 0)->orderBy('id')->limit($this->limit)->get();
        $logs = $logs->groupBy('task_id');
        foreach ($logs as $taskId => $taskLogs) {
            $nowTime = now();
            $task = CouponSendTask::find($taskId);
            $coupon = Coupon::find($task->coupon_id);
            //如果优惠券限量，则获取优惠券余量，只发送前面的人；
            $failedLogs = collect([]);
            if ($coupon->limit > 0 && $coupon->stock < ($taskLogs->count() * $task->num)) {
                $failedLogs = $taskLogs->slice($coupon->stock);
                $taskLogs = $taskLogs->slice(0, $coupon->stock);
            }
            if ($coupon->use_start_at && $coupon->use_end_at) {
                $useStartAt = $coupon->use_start_at;
                $useEndAt = $coupon->use_end_at;
            } else {
                $useStartAt = now();
                $useEndAt = now()->addDays($coupon->use_day);
            }

            //批量插入用户优惠券
            $insertUserCoupons = [];
            foreach ($taskLogs as $taskLog) {
                for ($i=0; $i< $taskLog->num; $i++) {
                    $insertUserCoupons[] = [
                        'user_id'       => $taskLog->user_id,
                        'coupon_id'     => $taskLog->coupon_id,
                        'coupon_name'   => $coupon->name,
                        'coupon_type'   => $coupon->type,
                        'coupon_amount' => (int) bcmul($coupon->amount, 100),
                        'coupon_threshold'=> (int) bcmul($coupon->threshold, 100),
                        'use_start_at'  => $useStartAt,
                        'use_end_at'    => $useEndAt,
                        'status'        => 0,
                        'created_at'    => $nowTime,
                        'updated_at'    => $nowTime,
                    ];
                }
            }
            try {
                DB::beginTransaction();

                count($insertUserCoupons) > 0 && UserCoupon::insert($insertUserCoupons);
                //更新任务日志状态；
                CouponTaskLog::whereIn('id', $taskLogs->pluck('id')->toArray())->update(['status'=>2]);
                $failedLogs->count() == 0 || CouponTaskLog::whereIn('id', $failedLogs->pluck('id')->toArray())->update(['status'=>3, 'remarks'=>'库存余量不足']);
                //更新任务对应券发送量，余量;
                $coupon->increment('sent', $taskLogs->count());
                if ($coupon->limit > 0) {//限量才减少余量
                    $coupon->decrement('stock', $taskLogs->count());
                }

                //更新如果是任务最后一批，更新任务状态;
                $taskTotalnum = CouponTaskLog::where('task_id', $taskId)->where('num', '>', 0)->count();
                $taskDidnum = CouponTaskLog::where('task_id', $taskId)->where('num', '>', 0)->where('status', '>', 0)->count();
                if ($taskTotalnum == $taskDidnum) {
                    $task->update(['status' => 3]);
                }
                DB::commit();
            } catch (Throwable $th) {
                DB::rollBack();
                report($th);
            }
        }
        $this->info('执行成功');
        return Command::SUCCESS;
    }
}