|
|
<?php
namespace App\Service\v3\Implementations;
use App\Constants\v3\OrderState;use App\Service\v3\Interfaces\BadgeServiceInterface;use Hyperf\Redis\Redis;use Hyperf\Utils\ApplicationContext;
class BadgeService implements BadgeServiceInterface{
/** * @inheritDoc */ public function doByOrder($userId, $storeIds, $globalOrderId, $orderState) {
switch ($orderState) { case OrderState::UNPAID: # 待付款（用户）
$this->sAddUserOrder('unpaid', $userId, $globalOrderId); break;
case OrderState::CANCELED: # 订单取消（用户）
$this->sAddUserOrder('canceled', $userId, $globalOrderId);
foreach ($storeIds as $key => &$storeId) { $this->sAddStoreOrder('canceled', $storeId, $globalOrderId); } break;
case OrderState::PAID: # 已付款（用户）
$this->sAddUserOrder('receiving', $userId, $globalOrderId);
foreach ($storeIds as $key => &$storeId) { $this->sAddStoreOrder('paid', $storeId, $globalOrderId); } break;
case OrderState::REFUNDING: # 用户申请退款
case OrderState::REFUNDED: # 后台同意退款
case OrderState::REFUND_REFUSE: # 后台拒绝退款
$this->sAddUserOrder('refund', $userId, $globalOrderId);
foreach ($storeIds as $key => &$storeId) { $this->sAddStoreOrder('refund', $storeId, $globalOrderId); } break;
case OrderState::REJECTION: # 后台拒单（后台）
$this->sAddUserOrder('rejection', $userId, $globalOrderId);
foreach ($storeIds as $key => &$storeId) { $this->sAddStoreOrder('rejection', $storeId, $globalOrderId); } break;
case OrderState::DELIVERY: # 后台接单（后台）
$this->sAddUserOrder('receiving', $userId, $globalOrderId);
foreach ($storeIds as $key => &$storeId) { $this->sAddStoreOrder('delivery', $storeId, $globalOrderId); } break;
case OrderState::COMPLETED: # 订单完成（用户或后台操作）
case OrderState::EVALUATED: # 订单评价（用户）
$this->sAddUserOrder('finish', $userId, $globalOrderId);
foreach ($storeIds as $key => &$storeId) { $this->sAddStoreOrder('finish', $storeId, $globalOrderId); } break; } }
public function allByUserOrder($userId) { $redis = ApplicationContext::getContainer()->get(Redis::class); $redisHName = 'badge:user'; $redisHKey = 'user_id_'.$userId;
// 取出当前用户的key的badge(key=>value json串)
$userBadges = $redis->hGet($redisHName, $redisHKey); $userBadges = json_decode($userBadges, true);
return [ 'unpaid' => isset($userBadges['unpaid']) ? count($userBadges['unpaid']) : 0, 'receiving' => isset($userBadges['receiving']) ? count($userBadges['receiving']) : 0, 'finish' => isset($userBadges['finish']) ? count($userBadges['finish']) : 0, 'refund' => isset($userBadges['refund']) ? count($userBadges['refund']) : 0, 'canceled' => isset($userBadges['canceled']) ? count($userBadges['canceled']) : 0, 'rejection' => isset($userBadges['rejection']) ? count($userBadges['rejection']) : 0, 'unpaid_arr' => $userBadges['unpaid'] ?? [], 'receiving_arr' => $userBadges['receiving'] ?? [], 'finish_arr' => $userBadges['finish'] ?? [], 'refund_arr' => $userBadges['refund'] ?? [], 'canceled_arr' => $userBadges['canceled'] ?? [], 'rejection_arr' => $userBadges['rejection'] ?? [], ];
// return [
// 'unpaid' => count($redis->sMembers('badge_unpaid_user_'.$userId)),
// 'receiving' => count($redis->sMembers('badge_receiving_user_'.$userId)),
// 'finish' => count($redis->sMembers('badge_finish_user_'.$userId)),
// 'refund' => count($redis->sMembers('badge_refund_user_'.$userId)),
// 'canceled' => count($redis->sMembers('badge_canceled_user_'.$userId)),
// 'rejection' => count($redis->sMembers('badge_rejection_store_'.$userId)),
// ];
}
/** * @inheritDoc */ public function allByStoreOrder($storeId) { $redis = ApplicationContext::getContainer()->get(Redis::class); $redisHName = 'badge:store'; $redisHKey = 'store_id_'.$storeId;
// 取出当前用户的key的badge(key=>value json串)
$storeBadges = $redis->hGet($redisHName, $redisHKey); $storeBadges = json_decode($storeBadges, true);
return [ 'paid' => isset($storeBadges['paid']) ? count($storeBadges['paid']) : 0, 'delivery' => isset($storeBadges['delivery']) ? count($storeBadges['delivery']) : 0, 'finish' => isset($storeBadges['finish']) ? count($storeBadges['finish']) : 0, 'refund' => isset($storeBadges['refund']) ? count($storeBadges['refund']) : 0, 'canceled' => isset($storeBadges['canceled']) ? count($storeBadges['canceled']) : 0, 'rejection' => isset($storeBadges['rejection']) ? count($storeBadges['rejection']) : 0, 'paid_arr' => $storeBadges['paid'] ?? [], 'delivery_arr' => $storeBadges['delivery'] ?? [], 'finish_arr' => $storeBadges['finish'] ?? [], 'refund_arr' => $storeBadges['refund'] ?? [], 'canceled_arr' => $storeBadges['canceled'] ?? [], 'rejection_arr' => $storeBadges['rejection'] ?? [], ];
// return [
// 'paid' => count($redis->sMembers('badge_paid_store_'.$storeId)),
// 'delivery' => count($redis->sMembers('badge_delivery_store_'.$storeId)),
// 'finish' => count($redis->sMembers('badge_finish_store_'.$storeId)),
// 'refund' => count($redis->sMembers('badge_refund_store_'.$storeId)),
// 'canceled' => count($redis->sMembers('badge_canceled_store_'.$storeId)),
// 'rejection' => count($redis->sMembers('badge_rejection_store_'.$storeId)),
// ];
}
/** * @inheritDoc */ public function sAddUserOrder($badge, $userId, $globalOrderId) { $redis = ApplicationContext::getContainer()->get(Redis::class); $redisHName = 'badge:user'; $redisHKey = 'user_id_'.$userId;
// 取出当前用户的key的badge(key=>value json串)
$userBadges = $redis->hGet($redisHName, $redisHKey); $userBadges = json_decode($userBadges, true);
$userBadges['unpaid'] = isset($userBadges['unpaid']) ? array_diff($userBadges['unpaid'], [$globalOrderId]) : []; # 移除用户待付款
$userBadges['receiving'] = isset($userBadges['receiving']) ? array_diff($userBadges['receiving'], [$globalOrderId]) : []; # 移除用户待收货
$userBadges['finish'] = isset($userBadges['finish']) ? array_diff($userBadges['finish'], [$globalOrderId]) : []; # 移除用户已完成
$userBadges['canceled'] = isset($userBadges['canceled']) ? array_diff($userBadges['canceled'], [$globalOrderId]) : []; # 移除用户已取消
$userBadges['refund'] = isset($userBadges['refund']) ? array_diff($userBadges['refund'], [$globalOrderId]) : []; # 移除用户退款售后
$userBadges['rejection'] = isset($userBadges['rejection']) ? array_diff($userBadges['rejection'], [$globalOrderId]) : []; # 移除用户拒单
$userBadges[$badge] = array_merge($userBadges[$badge], [$globalOrderId]); # 新增用户当前状态的值
$redis->hSet($redisHName,$redisHKey,json_encode($userBadges));
// $redis->sRem('badge_unpaid_user_'.$userId, $globalOrderId); # 移除用户待付款
// $redis->sRem('badge_receiving_user_'.$userId, $globalOrderId); # 移除用户待收货
// $redis->sRem('badge_finish_user_'.$userId, $globalOrderId); # 移除用户已完成
// $redis->sRem('badge_canceled_user_'.$userId, $globalOrderId); # 移除用户已取消
// $redis->sRem('badge_refund_user_'.$userId, $globalOrderId); # 移除用户退款售后
// $redis->sRem('badge_rejection_store_', $userId, $globalOrderId); # 移除用户拒单
// $redis->sAdd('badge_'.$badge.'_user_'.$userId, $globalOrderId); # 新增用户当前状态的值
}
/** * @inheritDoc */ public function sAddStoreOrder($badge, $storeId, $globalOrderId) { $redis = ApplicationContext::getContainer()->get(Redis::class); $redisHName = 'badge:store'; $redisHKey = 'store_id_'.$storeId;
// 取出当前用户的key的badge(key=>value json串)
$storeBadges = $redis->hGet($redisHName, $redisHKey); $storeBadges = json_decode($storeBadges, true);
$storeBadges['paid'] = isset($storeBadges['paid']) ? array_diff($storeBadges['paid'], [$globalOrderId]) : []; # 移除商户待接单
$storeBadges['delivery'] = isset($storeBadges['delivery']) ? array_diff($storeBadges['delivery'], [$globalOrderId]) : []; # 移除商户待送达
$storeBadges['finish'] = isset($storeBadges['finish']) ? array_diff($storeBadges['finish'], [$globalOrderId]) : []; # 移除商户已完成
$storeBadges['canceled'] = isset($storeBadges['canceled']) ? array_diff($storeBadges['canceled'], [$globalOrderId]) : []; # 移除商户已取消
$storeBadges['refund'] = isset($storeBadges['refund']) ? array_diff($storeBadges['refund'], [$globalOrderId]) : []; # 移除商户退款售后
$storeBadges['rejection'] = isset($storeBadges['rejection']) ? array_diff($storeBadges['rejection'], [$globalOrderId]) : []; # 移除商户拒单
$storeBadges[$badge] = array_merge($storeBadges[$badge], [$globalOrderId]); # 新增商户当前状态的值
$redis->hSet($redisHName,$redisHKey,json_encode($storeBadges));
// $redis->sRem('badge_paid_store_'.$storeId, $globalOrderId); # 移除商户待接单
// $redis->sRem('badge_delivery_store_'.$storeId, $globalOrderId); # 移除商户待送达
// $redis->sRem('badge_finish_store_'.$storeId, $globalOrderId); # 移除商户已完成
// $redis->sRem('badge_canceled_store_'.$storeId, $globalOrderId); # 移除商户已取消
// $redis->sRem('badge_refund_store_'.$storeId, $globalOrderId); # 移除商户退款售后
// $redis->sRem('badge_rejection_store_', $storeId, $globalOrderId); # 移除商户拒单
// $redis->sAdd('badge_'.$badge.'_store_'.$storeId, $globalOrderId); # 新增用户当前状态的值
}
/** * @inheritDoc */ public function clearUserOrder($userId, $badge = 'all', $globalOrderId = '') { $redis = ApplicationContext::getContainer()->get(Redis::class); $redisHName = 'badge:user'; $redisHKey = 'user_id_'.$userId;
// 取出当前用户的key的badge(key=>value json串)
$userBadges = $redis->hGet($redisHName, $redisHKey); $userBadges = json_decode($userBadges, true);
if ($badge == 'all') {
$redis->hDel($redisHName, $redisHKey);
// $redis->del('badge_unpaid_user_'.$userId); # 移除用户待付款
// $redis->del('badge_receiving_user_'.$userId); # 移除用户待收货
// $redis->del('badge_finish_user_'.$userId); # 移除用户已完成
// $redis->del('badge_canceled_user_'.$userId); # 移除用户已取消
// $redis->del('badge_refund_user_'.$userId); # 移除用户退款售后
// $redis->del('badge_rejection_store_', $userId); # 移除用户拒单
} else {
if ($globalOrderId) { $userBadges[$badge] = isset($userBadges[$badge]) ? array_diff($userBadges[$badge], [$globalOrderId]) : []; # 移除当前状态里的某个值
} else { unset($userBadges[$badge]); } $redis->hSet($redisHName,$redisHKey,json_encode($userBadges));
// $redis->del('badge_'.$badge.'_user_'.$userId);
} }
/** * @inheritDoc */ public function clearStoreOrder($storeId, $badge = 'all', $globalOrderId = '') { $redis = ApplicationContext::getContainer()->get(Redis::class); $redisHName = 'badge:store'; $redisHKey = 'store_id_'.$storeId;
// 取出当前用户的key的badge(key=>value json串)
$storeBadges = $redis->hGet($redisHName, $redisHKey); $storeBadges = json_decode($storeBadges, true);
if ($badge == 'all') {
$redis->hDel($redisHName, $redisHKey);
// $redis->del('badge_paid_store_'.$storeId); # 移除商户待付款
// $redis->del('badge_delivery_store_'.$storeId); # 移除商户待收货
// $redis->del('badge_finish_store_'.$storeId); # 移除商户已完成
// $redis->del('badge_canceled_store_'.$storeId); # 移除商户已取消
// $redis->del('badge_refund_store_'.$storeId); # 移除商户退款售后
// $redis->del('badge_rejection_store_', $storeId); # 移除商户拒单
} else {
if ($globalOrderId) { $storeBadges[$badge] = isset($storeBadges[$badge]) ? array_diff($storeBadges[$badge], [$globalOrderId]) : []; # 移除当前状态里的某个值
} else { unset($storeBadges[$badge]); } $redis->hSet($redisHName,$redisHKey,json_encode($storeBadges));
// $redis->del('badge_'.$badge.'_store_'.$storeId);
} }}
|
