<?php
|
|
namespace app\job\event;
|
|
use think\facade\Cache;
|
use app\job\model\plus\vip\User as VipUserModel;
|
|
/**
|
* VIP用户事件管理
|
*/
|
class VipUser
|
{
|
// 模型
|
private $model;
|
|
/**
|
* 执行函数
|
*/
|
public function handle()
|
{
|
try {
|
$this->model = new VipUserModel();
|
$cacheKey = "task_space_VipUser";
|
if (!Cache::has($cacheKey)) {
|
// 处理用户升级逻辑
|
$this->processUserUpgrades();
|
|
// 处理用户降级逻辑
|
$this->processUserDowngrades();
|
|
Cache::set($cacheKey, time(), 60);
|
}
|
} catch (\Throwable $e) {
|
echo 'ERROR VipUser: ' . $e->getMessage() . PHP_EOL;
|
log_write('VipUser TASK : ' . '__ ' . $e->getMessage(), 'task');
|
}
|
return true;
|
}
|
|
/**
|
* 处理用户升级
|
*/
|
private function processUserUpgrades()
|
{
|
// 获取需要升级的用户列表
|
$list = $this->model->getUpgradeList();
|
if ($list->isEmpty()) return false;
|
|
// 处理逻辑...
|
$processedIds = [];
|
foreach ($list as $item) {
|
// 具体处理逻辑
|
$processedIds[] = $item['user_id'];
|
}
|
|
// 标记已处理
|
if (!empty($processedIds)) {
|
$this->model->processGradeChange($processedIds, true);
|
}
|
|
// 记录日志
|
$this->dologs('processUserUpgrades', ['Count' => count($processedIds)]);
|
return true;
|
}
|
|
/**
|
* 处理用户降级
|
*/
|
private function processUserDowngrades()
|
{
|
// 获取需要降级的用户列表
|
$list = $this->model->getDowngradeList();
|
if ($list->isEmpty()) return false;
|
|
// 处理逻辑...
|
$processedIds = [];
|
foreach ($list as $item) {
|
// 具体处理逻辑
|
$processedIds[] = $item['user_id'];
|
}
|
|
// 标记已处理
|
if (!empty($processedIds)) {
|
$this->model->processGradeChange($processedIds, false);
|
}
|
|
// 记录日志
|
$this->dologs('processUserDowngrades', ['Count' => count($processedIds)]);
|
return true;
|
}
|
|
/**
|
* 记录日志
|
*/
|
private function dologs($method, $params = [])
|
{
|
$value = 'behavior VipUser --' . $method;
|
foreach ($params as $key => $val) {
|
$value .= ' --' . $key . ' ' . (is_array($val) ? json_encode($val) : $val);
|
}
|
return log_write($value, 'task');
|
}
|
}
|
