hyperf-chat/app/Command/TestCommand.php

89 lines
2.3 KiB
PHP

<?php
declare(strict_types=1);
namespace App\Command;
use App\Cache\VoteStatisticsCache;
use App\Model\Talk\TalkRecordsVote;
use App\Model\UsersFriend;
use Hyperf\Command\Command as HyperfCommand;
use Hyperf\Command\Annotation\Command;
use Hyperf\DbConnection\Db;
use Hyperf\Utils\Arr;
use Psr\Container\ContainerInterface;
use Hyperf\Guzzle\ClientFactory;
use function _HumbugBox39a196d4601e\RingCentral\Psr7\build_query;
/**
* @Command
*/
class TestCommand extends HyperfCommand
{
/**
* @var ContainerInterface
*/
protected $container;
public function __construct(ContainerInterface $container)
{
$this->container = $container;
parent::__construct('test:command');
}
public function configure()
{
parent::configure();
$this->setDescription('Hyperf Demo Command');
}
public function handle()
{
$this->updateData();
//$api = config('juhe_api.ip');
//$options = [];
//$client = di()->get(ClientFactory::class)->create($options);
//$params = [
// 'ip' => '47.105.180.123',
// 'key' => $api['key'],
//];
//
//$address = '';
//$response = $client->get($api['api'] . '?' . http_build_query($params));
//if ($response->getStatusCode() == 200) {
// $result = json_decode($response->getBody()->getContents(), true);
// if ($result['resultcode'] == 200) {
// unset($result['result']['Isp']);
// $address = join(' ', $result['result']);
// }
//}
//
//var_dump($address);
}
// 更新好友表数据
public function updateData()
{
$max = UsersFriend::max('id');
UsersFriend::where('id', '<=', $max)->chunk(1000, function ($rows) {
$arr = [];
foreach ($rows as $row) {
$arr[] = [
'user_id' => $row->friend_id,
'friend_id' => $row->user_id,
'status' => 1,
'remark' => '',
'updated_at' => date('Y-m-d H:i:s'),
'created_at' => date('Y-m-d H:i:s'),
];
}
UsersFriend::insert($arr);
});
}
}