69 lines
2.1 KiB
PHP
69 lines
2.1 KiB
PHP
|
<?php
|
|||
|
|
|
|||
|
|
namespace App\Jobs;
|
|||
|
|
|
|||
|
|
use Illuminate\Bus\Queueable;
|
|||
|
|
use Illuminate\Queue\SerializesModels;
|
|||
|
|
use Illuminate\Queue\InteractsWithQueue;
|
|||
|
|
use Illuminate\Contracts\Queue\ShouldQueue;
|
|||
|
|
use Illuminate\Foundation\Bus\Dispatchable;
|
|||
|
|
use App\Models\Coin;
|
|||
|
|
use App\Models\CoinLog;
|
|||
|
|
use App\Http\Response\ResponseJson;
|
|||
|
|
use Illuminate\Support\Facades\Redis;
|
|||
|
|
|
|||
|
|
class CheckCoinSafe implements ShouldQueue
|
|||
|
|
{
|
|||
|
|
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
|
|||
|
|
use ResponseJson;
|
|||
|
|
protected $user_id;
|
|||
|
|
/**
|
|||
|
|
* Create a new job instance.
|
|||
|
|
*
|
|||
|
|
* @return void
|
|||
|
|
*/
|
|||
|
|
public function __construct($user_id)
|
|||
|
|
{
|
|||
|
|
$this->user_id = $user_id;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Execute the job.
|
|||
|
|
*
|
|||
|
|
* @return void
|
|||
|
|
*/
|
|||
|
|
public function handle()
|
|||
|
|
{
|
|||
|
|
try {
|
|||
|
|
//coin账号
|
|||
|
|
$coin = Coin::where('user_id', $this->user_id)->first();
|
|||
|
|
if (empty($coin)) throw new \Exception("用户id：".$this->user_id."，coin账号不存在");
|
|||
|
|
//监听时间间隔 单位分钟
|
|||
|
|
$key = 'coin_safe_time';
|
|||
|
|
$coin_safe_time = Redis::get($key);
|
|||
|
|
if (empty($coin_safe_time)) {
|
|||
|
|
$coin_safe_time = 5;
|
|||
|
|
Redis::set($key, $coin_safe_time);
|
|||
|
|
}
|
|||
|
|
//监听分享用户数 单位个
|
|||
|
|
$num_key = 'coin_share_num';
|
|||
|
|
$coin_share_num = Redis::get($num_key);
|
|||
|
|
if (empty($coin_share_num)) {
|
|||
|
|
$coin_share_num = 10;
|
|||
|
|
Redis::set($num_key, $coin_share_num);
|
|||
|
|
}
|
|||
|
|
$start_time = date('Y-m-d H:i:s', time() - $coin_safe_time * 60);
|
|||
|
|
$end_time = date('Y-m-d H:i:s');
|
|||
|
|
$count = CoinLog::where('user_id', $this->user_id)->where('type', 'INVIT')->where('remark', "商家入驻")->whereBetween('created_at', [$start_time, $end_time])->count();
|
|||
|
|
if ($count >= $coin_share_num) {
|
|||
|
|
$coin->is_safe = 0;
|
|||
|
|
$coin->save();
|
|||
|
|
}
|
|||
|
|
return true;
|
|||
|
|
} catch (\Exception $e) {
|
|||
|
|
$this->getError($e);
|
|||
|
|
return false;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|