Jason/zh-chat-server
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

init

Browse Source
This commit is contained in:
Jason.Chen
2022-11-01 11:07:41 +08:00
commit c23de98690
131 changed files with 14088 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

158
app/Api/Controllers/InitController.php Normal file
View File

@@ -0,0 +1,158 @@
<?php
namespace App\Api\Controllers;
use App\Jobs\CheckUser;
use App\Jobs\ImportFriends;
use App\Jobs\ImportUser;
use App\Models\OriginUser;
use App\Models\User;
use GuzzleHttp\Client;
class InitController extends Controller
{
public function check()
{
$params = [
'jsonrpc' => '2.0',
'id' => 1,
'method' => 'Chain33.Query',
'params' => [
[
'execer' => 'chat',
'funcName' => 'GetFriends',
'payload' => [
'mainAddress' => '12dUut3dG5xWi6JPDMjSSK6s2JPcfeKYL1',
'count' => 2000,
]
]
],
];
$client = new Client([
'base_uri' => '152.136.224.167:8901'
]);
$result = $client->post('', [
'body' => json_encode($params),
]);
$json = json_decode($result->getBody()->getContents(), true);
$collect = collect($json['result']['friends']);
dump($collect);
// foreach (User::all() as $user) {
// CheckUser::dispatch($user);
// }
}
public function users()
{
foreach (User::all() as $user) {
ImportUser::dispatch($user);
}
}
public function friend()
{
$params = [
'jsonrpc' => '2.0',
'id' => 1,
'method' => 'Chain33.Query',
'params' => [
[
'execer' => 'chat',
'funcName' => 'GetFriends',
'payload' => [
'mainAddress' => '1125cmMhWBYFwDwyMsr3Kwg4WxxAVPV2Pw',
'count' => 2000,
]
]
],
];
$client = new Client([
'base_uri' => '152.136.224.167:8901'
]);
$result = $client->post('', [
'body' => json_encode($params),
]);
$json = json_decode($result->getBody()->getContents(), true);
$collect = collect($json['result']['friends']);
dd($collect);
$imParams = [
'From_Account' => '1',
'StartIndex' => 0,
'StandardSequence' => 0,
'CustomSequence' => 0,
];
$vars = app('im')->send('sns', 'friend_get', $imParams);
dd($vars);
// foreach (User::all() as $user) {
// ImportFriends::dispatch($user);
// }
}
public function delete()
{
// $imParams = [
// 'DeleteItem' => [
// [
// "UserID" => "1",
// ]
// ],
// ];
//
// $vars = app('im')->send('im_open_login_svc', 'account_delete', $imParams);
// dd($vars);
}
/**
* Notes : 同步用户
*
* @Date : 2022/10/21 15:15
* @Author : <Jason.C>
*/
public function sync()
{
// $users = OriginUser::all();
// // $users = OriginUser::inRandomOrder()->limit(3)->get();
// foreach ($users as $user) {
// User::create([
// 'username' => $user->address,
// 'phone' => $user->phone,
// 'email' => $user->email,
// ]);
// }
}
public function info()
{
$params = [
'jsonrpc' => '2.0',
'id' => 1,
'method' => 'Chain33.Query',
'params' => [
[
'execer' => 'chat',
'funcName' => 'GetUser',
'payload' => [
'mainAddress' => '112CBev1zHsTsjxxRZoKwyuqpiXcedbfMn',
'targetAddress' => '112CBev1zHsTsjxxRZoKwyuqpiXcedbfMn',
]
]
],
];
$client = new Client([
'base_uri' => '152.136.224.167:8901'
]);
$result = $client->post('', [
'body' => json_encode($params),
]);
$json = json_decode($result->getBody()->getContents(), true);
$collect = collect($json['result']['fields']);
dump($collect);
}
}