pllx
374 lines
13 KiB
PHP
374 lines
13 KiB
PHP
<?php
|
||
|
||
/**
|
||
* 文件功能：商店业务逻辑服务层
|
||
* 处理商品购买、周卡激活/覆盖、改名卡使用等全部核心业务
|
||
*/
|
||
|
||
namespace App\Services;
|
||
|
||
use App\Models\ShopItem;
|
||
use App\Models\User;
|
||
use App\Models\UsernameBlacklist;
|
||
use App\Models\UserPurchase;
|
||
use Illuminate\Support\Carbon;
|
||
use Illuminate\Support\Facades\DB;
|
||
|
||
class ShopService
|
||
{
|
||
/**
|
||
* @param DecorationService $decorationService 装扮服务
|
||
*/
|
||
public function __construct(
|
||
private readonly DecorationService $decorationService,
|
||
) {}
|
||
|
||
/**
|
||
* 购买商品入口：扣金币、按类型分发处理
|
||
*
|
||
* @return array{ok:bool, message:string, play_effect?:string, quantity?:int, total_price?:int}
|
||
*/
|
||
public function buyItem(User $user, ShopItem $item, int $quantity = 1): array
|
||
{
|
||
if ($quantity !== 1 && $item->type !== ShopItem::TYPE_SIGN_REPAIR) {
|
||
return ['ok' => false, 'message' => '该商品暂不支持批量购买。'];
|
||
}
|
||
|
||
$totalPrice = $item->price * $quantity;
|
||
|
||
// 校验金币是否足够
|
||
if ($user->jjb < $totalPrice) {
|
||
return ['ok' => false, 'message' => "金币不足，购买 [{$item->name}] 需要 {$totalPrice} 金币，当前仅有 {$user->jjb} 金币。"];
|
||
}
|
||
|
||
return match ($item->type) {
|
||
'instant' => $this->buyInstant($user, $item),
|
||
'duration' => $this->buyWeekCard($user, $item),
|
||
'one_time' => $this->buyRenameCard($user, $item),
|
||
'ring' => $this->buyRing($user, $item),
|
||
'auto_fishing' => $this->buyAutoFishingCard($user, $item),
|
||
ShopItem::TYPE_SIGN_REPAIR => $this->buySignRepairCard($user, $item, $quantity),
|
||
// ── 个人装扮购买（委托给 DecorationService）───────────────
|
||
'msg_bubble' => $this->decorationService->purchase($user, $item, $quantity),
|
||
'msg_name_color' => $this->decorationService->purchase($user, $item, $quantity),
|
||
'msg_text_color' => $this->decorationService->purchase($user, $item, $quantity),
|
||
'avatar_frame' => $this->decorationService->purchase($user, $item, $quantity),
|
||
default => ['ok' => false, 'message' => '未知商品类型'],
|
||
};
|
||
}
|
||
|
||
/**
|
||
* 购买单次特效卡：立即扣金币，记录已用，返回需要播放的特效 key
|
||
*
|
||
* @return array{ok:bool, message:string, play_effect?:string}
|
||
*/
|
||
public function buyInstant(User $user, ShopItem $item): array
|
||
{
|
||
DB::transaction(function () use ($user, $item) {
|
||
// 扣除金币
|
||
$user->decrement('jjb', $item->price);
|
||
// 写入已使用记录（用于统计）
|
||
UserPurchase::create([
|
||
'user_id' => $user->id,
|
||
'shop_item_id' => $item->id,
|
||
'status' => 'used',
|
||
'price_paid' => $item->price,
|
||
'used_at' => Carbon::now(),
|
||
]);
|
||
});
|
||
|
||
return [
|
||
'ok' => true,
|
||
'message' => "购买成功！{$item->icon} {$item->name} 正在为您播放...",
|
||
'play_effect' => $item->effectKey(), // 返回特效 key 让前端立即播放
|
||
];
|
||
}
|
||
|
||
/**
|
||
* 购买周卡：取消旧周卡（金币不退），激活新周卡，有效期7天
|
||
*
|
||
* @return array{ok:bool, message:string}
|
||
*/
|
||
public function buyWeekCard(User $user, ShopItem $item): array
|
||
{
|
||
DB::transaction(function () use ($user, $item) {
|
||
// 将所有已激活的周卡标记为 cancelled（金币不退）
|
||
UserPurchase::where('user_id', $user->id)
|
||
->where('status', 'active')
|
||
->whereHas('shopItem', fn ($q) => $q->where('type', 'duration'))
|
||
->update(['status' => 'cancelled']);
|
||
|
||
// 扣除金币
|
||
$user->decrement('jjb', $item->price);
|
||
|
||
// 写入新的激活记录
|
||
UserPurchase::create([
|
||
'user_id' => $user->id,
|
||
'shop_item_id' => $item->id,
|
||
'status' => 'active',
|
||
'price_paid' => $item->price,
|
||
'expires_at' => Carbon::now()->addDays($item->duration_days ?? 7),
|
||
]);
|
||
});
|
||
|
||
return ['ok' => true, 'message' => "购买成功！{$item->icon} {$item->name} 已激活，下次登录自动生效（连续7天）。"];
|
||
}
|
||
|
||
/**
|
||
* 购买改名卡：扣金币、写 active 记录备用
|
||
*
|
||
* @return array{ok:bool, message:string}
|
||
*/
|
||
public function buyRenameCard(User $user, ShopItem $item): array
|
||
{
|
||
// 检查是否已有未使用的改名卡
|
||
$existing = UserPurchase::where('user_id', $user->id)
|
||
->where('status', 'active')
|
||
->whereHas('shopItem', fn ($q) => $q->where('slug', 'rename_card'))
|
||
->exists();
|
||
|
||
if ($existing) {
|
||
return ['ok' => false, 'message' => '您已有一张未使用的改名卡，使用后再购买。'];
|
||
}
|
||
|
||
DB::transaction(function () use ($user, $item) {
|
||
$user->decrement('jjb', $item->price);
|
||
UserPurchase::create([
|
||
'user_id' => $user->id,
|
||
'shop_item_id' => $item->id,
|
||
'status' => 'active',
|
||
'price_paid' => $item->price,
|
||
]);
|
||
});
|
||
|
||
return ['ok' => true, 'message' => '改名卡购买成功！请在商店中使用改名卡修改昵称。'];
|
||
}
|
||
|
||
/**
|
||
* 使用改名卡：校验新名、加黑名单、更新用户名
|
||
*
|
||
* @param string $newName 新昵称
|
||
* @return array{ok:bool, message:string}
|
||
*/
|
||
public function useRenameCard(User $user, string $newName): array
|
||
{
|
||
$newName = trim($newName);
|
||
|
||
// 格式校验：1-10字符，中英文数字下划线
|
||
if (! preg_match('/^[\x{4e00}-\x{9fa5}a-zA-Z0-9_]{1,10}$/u', $newName)) {
|
||
return ['ok' => false, 'message' => '新昵称格式不合法（1-10字，中英文/数字/下划线）。'];
|
||
}
|
||
|
||
// 不能与自己现有名相同
|
||
if ($newName === $user->username) {
|
||
return ['ok' => false, 'message' => '新昵称与当前昵称相同，请重新输入。'];
|
||
}
|
||
|
||
// 不能与其他用户重名
|
||
if (User::where('username', $newName)->exists()) {
|
||
return ['ok' => false, 'message' => '该昵称已被他人注册，请换一个。'];
|
||
}
|
||
|
||
// 不能在黑名单保留期内
|
||
if ($blockingRecord = UsernameBlacklist::getBlockingRecord($newName)) {
|
||
$reason = '';
|
||
if ($blockingRecord->type === 'permanent') {
|
||
$reason = "（包含敏感词：{$blockingRecord->username}）";
|
||
} else {
|
||
$reason = '（处于曾用名保护期）';
|
||
}
|
||
|
||
return ['ok' => false, 'message' => "该昵称已被系统禁止使用{$reason}。"];
|
||
}
|
||
|
||
// 查找有效的改名卡记录
|
||
$purchase = UserPurchase::where('user_id', $user->id)
|
||
->where('status', 'active')
|
||
->whereHas('shopItem', fn ($q) => $q->where('slug', 'rename_card'))
|
||
->first();
|
||
|
||
if (! $purchase) {
|
||
return ['ok' => false, 'message' => '您没有可用的改名卡，请先购买。'];
|
||
}
|
||
|
||
DB::transaction(function () use ($user, $purchase, $newName) {
|
||
$oldName = $user->username;
|
||
|
||
// 修改用户名
|
||
$user->username = $newName;
|
||
$user->save();
|
||
|
||
// 旧名入黑名单（保留30天）
|
||
UsernameBlacklist::updateOrCreate(
|
||
['username' => $oldName],
|
||
['reserved_until' => Carbon::now()->addDays(30), 'created_at' => Carbon::now()]
|
||
);
|
||
|
||
// 标记改名卡为已使用
|
||
$purchase->update(['status' => 'used', 'used_at' => Carbon::now()]);
|
||
});
|
||
|
||
return ['ok' => true, 'message' => "改名成功！您的新昵称为【{$newName}】，旧昵称将保留30天黑名单。注意：历史消息中的旧名不会同步修改。"];
|
||
}
|
||
|
||
/**
|
||
* 获取用户当前激活的周卡特效 key（如 fireworks/rain/lightning/snow）
|
||
* 过期的周卡会自动标记为 expired
|
||
*/
|
||
public function getActiveWeekEffect(User $user): ?string
|
||
{
|
||
$purchase = UserPurchase::with('shopItem')
|
||
->where('user_id', $user->id)
|
||
->where('status', 'active')
|
||
->whereHas('shopItem', fn ($q) => $q->where('type', 'duration'))
|
||
->first();
|
||
|
||
if (! $purchase) {
|
||
return null;
|
||
}
|
||
|
||
// 检查是否过期
|
||
if ($purchase->expires_at && $purchase->expires_at->isPast()) {
|
||
$purchase->update(['status' => 'expired']);
|
||
|
||
return null;
|
||
}
|
||
|
||
return $purchase->shopItem->effectKey();
|
||
}
|
||
|
||
/**
|
||
* 购买结婚戒指：扣金币、写入背包（active 状态，等待结婚时消耗）。
|
||
*
|
||
* @return array{ok:bool, message:string}
|
||
*/
|
||
public function buyRing(User $user, ShopItem $item): array
|
||
{
|
||
DB::transaction(function () use ($user, $item): void {
|
||
// 扣除金币
|
||
$user->decrement('jjb', $item->price);
|
||
// 写入背包（active = 未使用，求婚时变为 used_pending→used 或 lost）
|
||
UserPurchase::create([
|
||
'user_id' => $user->id,
|
||
'shop_item_id' => $item->id,
|
||
'status' => 'active',
|
||
'price_paid' => $item->price,
|
||
]);
|
||
});
|
||
|
||
return [
|
||
'ok' => true,
|
||
'message' => "💍 {$item->name} 购买成功！已放入背包，可用于求婚。",
|
||
];
|
||
}
|
||
|
||
/**
|
||
* 购买签到补签卡：扣金币并写入可消耗背包记录。
|
||
*
|
||
* @return array{ok:bool, message:string, quantity:int, total_price:int}
|
||
*/
|
||
public function buySignRepairCard(User $user, ShopItem $item, int $quantity = 1): array
|
||
{
|
||
$quantity = max(1, min(99, $quantity));
|
||
$totalPrice = $item->price * $quantity;
|
||
|
||
DB::transaction(function () use ($user, $item, $quantity, $totalPrice): void {
|
||
// 补签卡支持一次购买多张，扣款必须按总价执行。
|
||
$user->decrement('jjb', $totalPrice);
|
||
|
||
for ($i = 0; $i < $quantity; $i++) {
|
||
// 每张补签卡保留独立购买记录，补签时逐张消耗。
|
||
UserPurchase::create([
|
||
'user_id' => $user->id,
|
||
'shop_item_id' => $item->id,
|
||
'status' => 'active',
|
||
'price_paid' => $item->price,
|
||
]);
|
||
}
|
||
});
|
||
|
||
return [
|
||
'ok' => true,
|
||
'message' => "🗓️ {$item->name} × {$quantity} 购买成功！可在签到日历中补签漏掉的日期。",
|
||
'quantity' => $quantity,
|
||
'total_price' => $totalPrice,
|
||
];
|
||
}
|
||
|
||
/**
|
||
* 获取用户当前激活的改名卡（是否持有未用改名卡）
|
||
*/
|
||
public function hasRenameCard(User $user): bool
|
||
{
|
||
return UserPurchase::where('user_id', $user->id)
|
||
->where('status', 'active')
|
||
->whereHas('shopItem', fn ($q) => $q->where('slug', 'rename_card'))
|
||
->exists();
|
||
}
|
||
|
||
/**
|
||
* 获取用户可用补签卡数量。
|
||
*/
|
||
public function getSignRepairCardCount(User $user): int
|
||
{
|
||
return UserPurchase::query()
|
||
->where('user_id', $user->id)
|
||
->where('status', 'active')
|
||
->whereHas('shopItem', fn ($q) => $q->where('type', ShopItem::TYPE_SIGN_REPAIR))
|
||
->count();
|
||
}
|
||
|
||
/**
|
||
* 购买自动钓鱼卡：手刺金币，写入 active 记录，到期时间 = 现在 + duration_minutes。
|
||
*
|
||
* @return array{ok:bool, message:string}
|
||
*/
|
||
public function buyAutoFishingCard(User $user, ShopItem $item): array
|
||
{
|
||
$minutes = (int) $item->duration_minutes;
|
||
if ($minutes <= 0) {
|
||
return ['ok' => false, 'message' => '该钓鱼卡配置异常，请联系管理员。'];
|
||
}
|
||
|
||
DB::transaction(function () use ($user, $item, $minutes): void {
|
||
// 手刺金币
|
||
$user->decrement('jjb', $item->price);
|
||
// 写入背包（active，刻起计时）
|
||
UserPurchase::create([
|
||
'user_id' => $user->id,
|
||
'shop_item_id' => $item->id,
|
||
'status' => 'active',
|
||
'price_paid' => $item->price,
|
||
'expires_at' => Carbon::now()->addMinutes($minutes),
|
||
]);
|
||
});
|
||
|
||
$hours = round($minutes / 60, 1);
|
||
|
||
return [
|
||
'ok' => true,
|
||
'message' => "🎣 {$item->name}购买成功！{$hours}小时内鬼鱼自动收篼，尽情摆烂！",
|
||
];
|
||
}
|
||
|
||
/**
|
||
* 获取用户当前有效的自动钓鱼卡剩余分钟数（没有则返回 0）
|
||
*/
|
||
public function getActiveAutoFishingMinutesLeft(User $user): int
|
||
{
|
||
$purchase = UserPurchase::where('user_id', $user->id)
|
||
->where('status', 'active')
|
||
->whereNotNull('expires_at')
|
||
->whereHas('shopItem', fn ($q) => $q->where('type', 'auto_fishing'))
|
||
->where('expires_at', '>', Carbon::now())
|
||
->orderByDesc('expires_at') // 取最晚过期的
|
||
->first();
|
||
|
||
if (! $purchase) {
|
||
return 0;
|
||
}
|
||
|
||
return (int) Carbon::now()->diffInMinutes($purchase->expires_at, false);
|
||
}
|
||
}
|