测试
This commit is contained in:
@@ -27,8 +27,6 @@ class Base extends Model
|
|||||||
// 分组推送(广播)
|
// 分组推送(广播)
|
||||||
public static function gateway_query(string $method, array $params, bool $by_shop_id = false)
|
public static function gateway_query(string $method, array $params, bool $by_shop_id = false)
|
||||||
{
|
{
|
||||||
Log::info('消息->>>>>'.json_encode($params));
|
|
||||||
|
|
||||||
list($clientIdOrUid, $data) = $params;
|
list($clientIdOrUid, $data) = $params;
|
||||||
$data_arr = json_decode($data, true);
|
$data_arr = json_decode($data, true);
|
||||||
if(!empty($data_arr['msg_id'])) {
|
if(!empty($data_arr['msg_id'])) {
|
||||||
@@ -77,7 +75,7 @@ class Base extends Model
|
|||||||
if ($by_shop_id) {
|
if ($by_shop_id) {
|
||||||
$shopGroup = self::get_shopping_save_uid(self::$shop_id, 'all');
|
$shopGroup = self::get_shopping_save_uid(self::$shop_id, 'all');
|
||||||
Log::info('群发213123->>>>>'.self::$client_id);
|
Log::info('群发213123->>>>>'.self::$client_id);
|
||||||
Log::info('群发数据->>>>>'.Gateway::getClientInfoByGroup());
|
Log::info('群发数据->>>>>'.json_encode(Gateway::getClientSessionsByGroup($shopGroup)));
|
||||||
|
|
||||||
|
|
||||||
// 发送广播并将 self::$client_id 排除在外
|
// 发送广播并将 self::$client_id 排除在外
|
||||||
|
|||||||
Reference in New Issue
Block a user