Skip to content

H
hdg_user_api
Commit 05955bc6 by banice
Options

lumen准备升级到5.6

parent 433d7c84
Showing with 4660 additions and 127 deletions
Lib/Gateway.php 0 → 100644
<?php
namespace Lib;
use \Exception;
/**
* This file is part of workerman.
*
* Licensed under The MIT License
* For full copyright and license information, please see the MIT-LICENSE.txt
* Redistributions of files must retain the above copyright notice.
*
* @author walkor<walkor@workerman.net>
* @copyright walkor<walkor@workerman.net>
* @link http://www.workerman.net/
* @license http://www.opensource.org/licenses/mit-license.php MIT License
*/
/**
* 数据发送相关
* @version 3.0.10
*/
class Gateway
{
/**
* gateway 实例
*
* @var object
*/
protected static $businessWorker = null;
/**
* 注册中心地址
*
* @var string
*/
// public static $registerAddress = 'cdzregister.default.svc.cluster.local:1239';
public static $registerAddress = '100.103.0.8:1239';
//public static $registerAddress = '127.0.0.1:1236';
/**
* 秘钥
* @var string
*/
public static $secretKey = '';
/**
* 链接超时时间
* @var int
*/
public static $connectTimeout = 3;
/**
* 与Gateway是否是长链接
* @var bool
*/
public static $persistentConnection = false;
/**
* 向所有客户端连接(或者 client_id_array 指定的客户端连接)广播消息
*
* @param string $message 向客户端发送的消息
* @param array $client_id_array 客户端 id 数组
* @param array $exclude_client_id 不给这些client_id发
* @param bool $raw 是否发送原始数据（即不调用gateway的协议的encode方法）
* @return void
* @throws Exception
*/
public static function sendToAll($message, $client_id_array = null, $exclude_client_id = null, $raw = false)
{
$gateway_data = GatewayProtocol::$empty;
$gateway_data['cmd'] = GatewayProtocol::CMD_SEND_TO_ALL;
$gateway_data['body'] = $message;
if ($raw) {
$gateway_data['flag'] |= GatewayProtocol::FLAG_NOT_CALL_ENCODE;
}
if ($exclude_client_id) {
if (!is_array($exclude_client_id)) {
$exclude_client_id = array($exclude_client_id);
}
if ($client_id_array) {
$exclude_client_id = array_flip($exclude_client_id);
}
}
if ($client_id_array) {
if (!is_array($client_id_array)) {
echo new \Exception('bad $client_id_array:' . var_export($client_id_array, true));
return;
}
$data_array = array();
foreach ($client_id_array as $client_id) {
if (isset($exclude_client_id[$client_id])) {
continue;
}
$address = Context::clientIdToAddress($client_id);
if ($address) {
$key = long2ip($address['local_ip']) . ":{$address['local_port']}";
$data_array[$key][$address['connection_id']] = $address['connection_id'];
}
}
foreach ($data_array as $addr => $connection_id_list) {
$the_gateway_data = $gateway_data;
$the_gateway_data['ext_data'] = json_encode(array('connections' => $connection_id_list));
static::sendToGateway($addr, $the_gateway_data);
}
return;
} elseif (empty($client_id_array) && is_array($client_id_array)) {
return;
}
if (!$exclude_client_id) {
return static::sendToAllGateway($gateway_data);
}
$address_connection_array = static::clientIdArrayToAddressArray($exclude_client_id);
// 如果有businessWorker实例，说明运行在workerman环境中，通过businessWorker中的长连接发送数据
if (static::$businessWorker) {
foreach (static::$businessWorker->gatewayConnections as $address => $gateway_connection) {
$gateway_data['ext_data'] = isset($address_connection_array[$address]) ?
json_encode(array('exclude' => $address_connection_array[$address])) : '';
/** @var TcpConnection $gateway_connection */
$gateway_connection->send($gateway_data);
}
} // 运行在其它环境中，通过注册中心得到gateway地址
else {
$all_addresses = static::getAllGatewayAddressesFromRegister();
if (!$all_addresses) {
throw new Exception('Gateway::getAllGatewayAddressesFromRegister() with registerAddress:' .
static::$registerAddress . ' return ' . var_export($all_addresses, true));
}
foreach ($all_addresses as $address) {
$gateway_data['ext_data'] = isset($address_connection_array[$address]) ?
json_encode(array('exclude' => $address_connection_array[$address])) : '';
static::sendToGateway($address, $gateway_data);
}
}
}
/**
* 向某个client_id对应的连接发消息
*
* @param int $client_id
* @param string $message
* @return void
*/
public static function sendToClient($client_id, $message)
{
return static::sendCmdAndMessageToClient($client_id, GatewayProtocol::CMD_SEND_TO_ONE, $message);
}
/**
* 判断某个uid是否在线
*
* @param string $uid
* @return int 0|1
*/
public static function isUidOnline($uid)
{
return (int)static::getClientIdByUid($uid);
}
/**
* 判断client_id对应的连接是否在线
*
* @param int $client_id
* @return int 0|1
*/
public static function isOnline($client_id)
{
$address_data = Context::clientIdToAddress($client_id);
if (!$address_data) {
return 0;
}
$address = long2ip($address_data['local_ip']) . ":{$address_data['local_port']}";
if (isset(static::$businessWorker)) {
if (!isset(static::$businessWorker->gatewayConnections[$address])) {
return 0;
}
}
$gateway_data = GatewayProtocol::$empty;
$gateway_data['cmd'] = GatewayProtocol::CMD_IS_ONLINE;
$gateway_data['connection_id'] = $address_data['connection_id'];
return (int)static::sendAndRecv($address, $gateway_data);
}
/**
* 获取所有在线用户的session，client_id为 key(弃用，请用getAllClientSessions代替)
*
* @param string $group
* @return array
*/
public static function getAllClientInfo($group = '')
{
echo "Warning: Gateway::getAllClientInfo is deprecated and will be removed in a future, please use Gateway::getAllClientSessions instead.";
return static::getAllClientSessions($group);
}
/**
* 获取所有在线client_id的session，client_id为 key
*
* @param string $group
* @return array
*/
public static function getAllClientSessions($group = '')
{
$gateway_data = GatewayProtocol::$empty;
if (!$group) {
$gateway_data['cmd'] = GatewayProtocol::CMD_GET_ALL_CLIENT_SESSIONS;
} else {
$gateway_data['cmd'] = GatewayProtocol::CMD_GET_CLINET_SESSUONS_BY_GROUP;
$gateway_data['ext_data'] = $group;
}
$status_data = array();
$all_buffer_array = static::getBufferFromAllGateway($gateway_data);
foreach ($all_buffer_array as $local_ip => $buffer_array) {
foreach ($buffer_array as $local_port => $data) {
if ($data) {
foreach ($data as $connection_id => $session_buffer) {
$client_id = Context::addressToClientId($local_ip, $local_port, $connection_id);
if ($client_id === Context::$client_id) {
$status_data[$client_id] = (array)$_SESSION;
} else {
$status_data[$client_id] = $session_buffer ? Context::sessionDecode($session_buffer) : array();
}
}
}
}
}
return $status_data;
}
/**
* 获取某个组的连接信息（弃用，请用getClientSessionsByGroup代替）
*
* @param string $group
* @return array
*/
public static function getClientInfoByGroup($group)
{
echo "Warning: Gateway::getClientInfoByGroup is deprecated and will be removed in a future, please use Gateway::getClientSessionsByGroup instead.";
return static::getAllClientSessions($group);
}
/**
* 获取某个组的所有client_id的session信息
*
* @param string $group
*
* @return array
*/
public static function getClientSessionsByGroup($group)
{
if (static::isValidGroupId($group)) {
return static::getAllClientSessions($group);
}
return array();
}
/**
* 获取所有在线client_id数
*
* @return int
*/
public static function getAllClientIdCount()
{
return static::getClientCountByGroup();
}
/**
* 获取所有在线client_id数(getAllClientIdCount的别名)
*
* @return int
*/
public static function getAllClientCount()
{
return static::getAllClientIdCount();
}
/**
* 获取某个组的在线client_id数
*
* @param string $group
* @return int
*/
public static function getClientIdCountByGroup($group = '')
{
$gateway_data = GatewayProtocol::$empty;
$gateway_data['cmd'] = GatewayProtocol::CMD_GET_CLIENT_COUNT_BY_GROUP;
$gateway_data['ext_data'] = $group;
$total_count = 0;
$all_buffer_array = static::getBufferFromAllGateway($gateway_data);
foreach ($all_buffer_array as $local_ip => $buffer_array) {
foreach ($buffer_array as $local_port => $count) {
if ($count) {
$total_count += $count;
}
}
}
return $total_count;
}
/**
* getClientIdCountByGroup 函数的别名
*
* @param string $group
* @return int
*/
public static function getClientCountByGroup($group = '')
{
return static::getClientIdCountByGroup($group);
}
/**
* 获取某个群组在线client_id列表
*
* @param string $group
* @return array
*/
public static function getClientIdListByGroup($group)
{
if (!static::isValidGroupId($group)) {
return array();
}
$data = static::select(array('uid'), array('groups' => is_array($group) ? $group : array($group)));
$client_id_map = array();
foreach ($data as $local_ip => $buffer_array) {
foreach ($buffer_array as $local_port => $items) {
//$items = ['connection_id'=>['uid'=>x, 'group'=>[x,x..], 'session'=>[..]], 'client_id'=>[..], ..];
foreach ($items as $connection_id => $info) {
$client_id = Context::addressToClientId($local_ip, $local_port, $connection_id);
$client_id_map[$client_id] = $client_id;
}
}
}
return $client_id_map;
}
/**
* 获取集群所有在线client_id列表
*
* @return array
*/
public static function getAllClientIdList()
{
return static::formatClientIdFromGatewayBuffer(static::select(array('uid')));
}
/**
* 格式化client_id
*
* @param $data
* @return array
*/
protected static function formatClientIdFromGatewayBuffer($data)
{
$client_id_list = array();
foreach ($data as $local_ip => $buffer_array) {
foreach ($buffer_array as $local_port => $items) {
//$items = ['connection_id'=>['uid'=>x, 'group'=>[x,x..], 'session'=>[..]], 'client_id'=>[..], ..];
foreach ($items as $connection_id => $info) {
$client_id = Context::addressToClientId($local_ip, $local_port, $connection_id);
$client_id_list[$client_id] = $client_id;
}
}
}
return $client_id_list;
}
/**
* 获取与 uid 绑定的 client_id 列表
*
* @param string $uid
* @return array
*/
public static function getClientIdByUid($uid)
{
$gateway_data = GatewayProtocol::$empty;
$gateway_data['cmd'] = GatewayProtocol::CMD_GET_CLIENT_ID_BY_UID;
$gateway_data['ext_data'] = $uid;
$client_list = array();
$all_buffer_array = static::getBufferFromAllGateway($gateway_data);
foreach ($all_buffer_array as $local_ip => $buffer_array) {
foreach ($buffer_array as $local_port => $connection_id_array) {
if ($connection_id_array) {
foreach ($connection_id_array as $connection_id) {
$client_list[] = Context::addressToClientId($local_ip, $local_port, $connection_id);
}
}
}
}
return $client_list;
}
/**
* 获取某个群组在线uid列表
*
* @param string $group
* @return array
*/
public static function getUidListByGroup($group)
{
if (!static::isValidGroupId($group)) {
return array();
}
$group = is_array($group) ? $group : array($group);
$data = static::select(array('uid'), array('groups' => $group));
$uid_map = array();
foreach ($data as $local_ip => $buffer_array) {
foreach ($buffer_array as $local_port => $items) {
//$items = ['connection_id'=>['uid'=>x, 'group'=>[x,x..], 'session'=>[..]], 'client_id'=>[..], ..];
foreach ($items as $connection_id => $info) {
if (!empty($info['uid'])) {
$uid_map[$info['uid']] = $info['uid'];
}
}
}
}
return $uid_map;
}
/**
* 获取某个群组在线uid数
*
* @param string $group
* @return int
*/
public static function getUidCountByGroup($group)
{
if (static::isValidGroupId($group)) {
return count(static::getUidListByGroup($group));
}
return 0;
}
/**
* 获取全局在线uid列表
*
* @return array
*/
public static function getAllUidList()
{
$data = static::select(array('uid'));
$uid_map = array();
foreach ($data as $local_ip => $buffer_array) {
foreach ($buffer_array as $local_port => $items) {
//$items = ['connection_id'=>['uid'=>x, 'group'=>[x,x..], 'session'=>[..]], 'client_id'=>[..], ..];
foreach ($items as $connection_id => $info) {
if (!empty($info['uid'])) {
$uid_map[$info['uid']] = $info['uid'];
}
}
}
}
return $uid_map;
}
/**
* 获取全局在线uid数
* @return int
*/
public static function getAllUidCount()
{
return count(static::getAllUidList());
}
/**
* 通过client_id获取uid
*
* @param $client_id
* @return mixed
*/
public static function getUidByClientId($client_id)
{
$data = static::select(array('uid'), array('client_id' => array($client_id)));
foreach ($data as $local_ip => $buffer_array) {
foreach ($buffer_array as $local_port => $items) {
//$items = ['connection_id'=>['uid'=>x, 'group'=>[x,x..], 'session'=>[..]], 'client_id'=>[..], ..];
foreach ($items as $info) {
return $info['uid'];
}
}
}
}
/**
* 获取所有在线的群组id
*
* @return array
*/
public static function getAllGroupIdList()
{
$gateway_data = GatewayProtocol::$empty;
$gateway_data['cmd'] = GatewayProtocol::CMD_GET_GROUP_ID_LIST;
$group_id_list = array();
$all_buffer_array = static::getBufferFromAllGateway($gateway_data);
foreach ($all_buffer_array as $local_ip => $buffer_array) {
foreach ($buffer_array as $local_port => $group_id_array) {
if (is_array($group_id_array)) {
foreach ($group_id_array as $group_id) {
if (!isset($group_id_list[$group_id])) {
$group_id_list[$group_id] = $group_id;
}
}
}
}
}
return $group_id_list;
}
/**
* 获取所有在线分组的uid数量，也就是每个分组的在线用户数
*
* @return array
*/
public static function getAllGroupUidCount()
{
$group_uid_map = static::getAllGroupUidList();
$group_uid_count_map = array();
foreach ($group_uid_map as $group_id => $uid_list) {
$group_uid_count_map[$group_id] = count($uid_list);
}
return $group_uid_count_map;
}
/**
* 获取所有分组uid在线列表
*
* @return array
*/
public static function getAllGroupUidList()
{
$data = static::select(array('uid', 'groups'));
$group_uid_map = array();
foreach ($data as $local_ip => $buffer_array) {
foreach ($buffer_array as $local_port => $items) {
//$items = ['connection_id'=>['uid'=>x, 'group'=>[x,x..], 'session'=>[..]], 'client_id'=>[..], ..];
foreach ($items as $connection_id => $info) {
if (empty($info['uid']) || empty($info['groups'])) {
break;
}
$uid = $info['uid'];
foreach ($info['groups'] as $group_id) {
if (!isset($group_uid_map[$group_id])) {
$group_uid_map[$group_id] = array();
}
$group_uid_map[$group_id][$uid] = $uid;
}
}
}
}
return $group_uid_map;
}
/**
* 获取所有群组在线client_id列表
*
* @return array
*/
public static function getAllGroupClientIdList()
{
$data = static::select(array('groups'));
$group_client_id_map = array();
foreach ($data as $local_ip => $buffer_array) {
foreach ($buffer_array as $local_port => $items) {
//$items = ['connection_id'=>['uid'=>x, 'group'=>[x,x..], 'session'=>[..]], 'client_id'=>[..], ..];
foreach ($items as $connection_id => $info) {
if (empty($info['groups'])) {
break;
}
$client_id = Context::addressToClientId($local_ip, $local_port, $connection_id);
foreach ($info['groups'] as $group_id) {
if (!isset($group_client_id_map[$group_id])) {
$group_client_id_map[$group_id] = array();
}
$group_client_id_map[$group_id][$client_id] = $client_id;
}
}
}
}
return $group_client_id_map;
}
/**
* 获取所有群组在线client_id数量，也就是获取每个群组在线连接数
*
* @return array
*/
public static function getAllGroupClientIdCount()
{
$group_client_map = static::getAllGroupClientIdList();
$group_client_count_map = array();
foreach ($group_client_map as $group_id => $client_id_list) {
$group_client_count_map[$group_id] = count($client_id_list);
}
return $group_client_count_map;
}
/**
* 根据条件到gateway搜索数据
*
* @param array $fields
* @param array $where
* @return array
*/
protected static function select($fields = array('session', 'uid', 'groups'), $where = array())
{
$t = microtime(true);
$gateway_data = GatewayProtocol::$empty;
$gateway_data['cmd'] = GatewayProtocol::CMD_SELECT;
$gateway_data['ext_data'] = array('fields' => $fields, 'where' => $where);
$gateway_data_list = array();
// 有client_id，能计算出需要和哪些gateway通讯，只和必要的gateway通讯能降低系统负载
if (isset($where['client_id'])) {
$client_id_list = $where['client_id'];
unset($gateway_data['ext_data']['where']['client_id']);
$gateway_data['ext_data']['where']['connection_id'] = array();
foreach ($client_id_list as $client_id) {
$address_data = Context::clientIdToAddress($client_id);
if (!$address_data) {
continue;
}
$address = long2ip($address_data['local_ip']) . ":{$address_data['local_port']}";
if (!isset($gateway_data_list[$address])) {
$gateway_data_list[$address] = $gateway_data;
}
$gateway_data_list[$address]['ext_data']['where']['connection_id'][$address_data['connection_id']] = $address_data['connection_id'];
}
foreach ($gateway_data_list as $address => $item) {
$gateway_data_list[$address]['ext_data'] = json_encode($item['ext_data']);
}
// 有其它条件，则还是需要向所有gateway发送
if (count($where) !== 1) {
$gateway_data['ext_data'] = json_encode($gateway_data['ext_data']);
foreach (static::getAllGatewayAddress() as $address) {
if (!isset($gateway_data_list[$address])) {
$gateway_data_list[$address] = $gateway_data;
}
}
}
$data = static::getBufferFromSomeGateway($gateway_data_list);
} else {
$gateway_data['ext_data'] = json_encode($gateway_data['ext_data']);
$data = static::getBufferFromAllGateway($gateway_data);
}
return $data;
}
/**
* 生成验证包，用于验证此客户端的合法性
*
* @return string
*/
protected static function generateAuthBuffer()
{
$gateway_data = GatewayProtocol::$empty;
$gateway_data['cmd'] = GatewayProtocol::CMD_GATEWAY_CLIENT_CONNECT;
$gateway_data['body'] = json_encode(array(
'secret_key' => static::$secretKey,
));
return GatewayProtocol::encode($gateway_data);
}
/**
* 批量向某些gateway发包，并得到返回数组
*
* @param array $gateway_data_array
* @return array
* @throws Exception
*/
protected static function getBufferFromSomeGateway($gateway_data_array)
{
$gateway_buffer_array = array();
$auth_buffer = static::$secretKey ? static::generateAuthBuffer() : '';
foreach ($gateway_data_array as $address => $gateway_data) {
if ($auth_buffer) {
$gateway_buffer_array[$address] = $auth_buffer . GatewayProtocol::encode($gateway_data);
} else {
$gateway_buffer_array[$address] = GatewayProtocol::encode($gateway_data);
}
}
return static::getBufferFromGateway($gateway_buffer_array);
}
/**
* 批量向所有 gateway 发包，并得到返回数组
*
* @param string $gateway_data
* @return array
* @throws Exception
*/
protected static function getBufferFromAllGateway($gateway_data)
{
$addresses = static::getAllGatewayAddress();
$gateway_buffer_array = array();
$gateway_buffer = GatewayProtocol::encode($gateway_data);
if (!is_array($gateway_data)) {
$gateway_buffer = static::$secretKey ? static::generateAuthBuffer() . $gateway_buffer : $gateway_buffer;
}
foreach ($addresses as $address) {
$gateway_buffer_array[$address] = $gateway_buffer;
}
return static::getBufferFromGateway($gateway_buffer_array);
}
/**
* 获取所有gateway内部通讯地址
*
* @return array
* @throws Exception
*/
protected static function getAllGatewayAddress()
{
if (isset(static::$businessWorker)) {
$addresses = static::$businessWorker->getAllGatewayAddresses();
if (empty($addresses)) {
throw new Exception('businessWorker::getAllGatewayAddresses return empty');
}
} else {
$addresses = static::getAllGatewayAddressesFromRegister();
if (empty($addresses)) {
return array();
}
}
return $addresses;
}
/**
* 批量向gateway发送并获取数据
* @param $gateway_buffer_array
* @return array
*/
protected static function getBufferFromGateway($gateway_buffer_array)
{
$client_array = $status_data = $client_address_map = $receive_buffer_array = $recv_length_array = array();
// 批量向所有gateway进程发送请求数据
foreach ($gateway_buffer_array as $address => $gateway_buffer) {
$client = stream_socket_client("tcp://$address", $errno, $errmsg, static::$connectTimeout);
if ($client && strlen($gateway_buffer) === stream_socket_sendto($client, $gateway_buffer)) {
$socket_id = (int)$client;
$client_array[$socket_id] = $client;
$client_address_map[$socket_id] = explode(':', $address);
$receive_buffer_array[$socket_id] = '';
}
}
// 超时5秒
$timeout = 5;
$time_start = microtime(true);
// 批量接收请求
while (count($client_array) > 0) {
$write = $except = array();
$read = $client_array;
if (@stream_select($read, $write, $except, $timeout)) {
foreach ($read as $client) {
$socket_id = (int)$client;
$buffer = stream_socket_recvfrom($client, 65535);
if ($buffer !== '' && $buffer !== false) {
$receive_buffer_array[$socket_id] .= $buffer;
$receive_length = strlen($receive_buffer_array[$socket_id]);
if (empty($recv_length_array[$socket_id]) && $receive_length >= 4) {
$recv_length_array[$socket_id] = current(unpack('N', $receive_buffer_array[$socket_id]));
}
if (!empty($recv_length_array[$socket_id]) && $receive_length >= $recv_length_array[$socket_id] + 4) {
unset($client_array[$socket_id]);
}
} elseif (feof($client)) {
unset($client_array[$socket_id]);
}
}
}
if (microtime(true) - $time_start > $timeout) {
break;
}
}
$format_buffer_array = array();
foreach ($receive_buffer_array as $socket_id => $buffer) {
$local_ip = ip2long($client_address_map[$socket_id][0]);
$local_port = $client_address_map[$socket_id][1];
$format_buffer_array[$local_ip][$local_port] = unserialize(substr($buffer, 4));
}
return $format_buffer_array;
}
/**
* 踢掉某个客户端，并以$message通知被踢掉客户端
*
* @param int $client_id
* @param string $message
* @return void
*/
public static function closeClient($client_id, $message = null)
{
if ($client_id === Context::$client_id) {
return static::closeCurrentClient($message);
} // 不是发给当前用户则使用存储中的地址
else {
$address_data = Context::clientIdToAddress($client_id);
if (!$address_data) {
return false;
}
$address = long2ip($address_data['local_ip']) . ":{$address_data['local_port']}";
return static::kickAddress($address, $address_data['connection_id'], $message);
}
}
/**
* 踢掉当前客户端，并以$message通知被踢掉客户端
*
* @param string $message
* @return bool
* @throws Exception
*/
public static function closeCurrentClient($message = null)
{
if (!Context::$connection_id) {
throw new Exception('closeCurrentClient can not be called in async context');
}
$address = long2ip(Context::$local_ip) . ':' . Context::$local_port;
return static::kickAddress($address, Context::$connection_id, $message);
}
/**
* 踢掉某个客户端并直接立即销毁相关连接
*
* @param int $client_id
* @return bool
*/
public static function destoryClient($client_id)
{
if ($client_id === Context::$client_id) {
return static::destoryCurrentClient();
} // 不是发给当前用户则使用存储中的地址
else {
$address_data = Context::clientIdToAddress($client_id);
if (!$address_data) {
return false;
}
$address = long2ip($address_data['local_ip']) . ":{$address_data['local_port']}";
return static::destroyAddress($address, $address_data['connection_id']);
}
}
/**
* 踢掉当前客户端并直接立即销毁相关连接
*
* @return bool
* @throws Exception
*/
public static function destoryCurrentClient()
{
if (!Context::$connection_id) {
throw new Exception('destoryCurrentClient can not be called in async context');
}
$address = long2ip(Context::$local_ip) . ':' . Context::$local_port;
return static::destroyAddress($address, Context::$connection_id);
}
/**
* 将 client_id 与 uid 绑定
*
* @param int $client_id
* @param int|string $uid
* @return void
*/
public static function bindUid($client_id, $uid)
{
static::sendCmdAndMessageToClient($client_id, GatewayProtocol::CMD_BIND_UID, '', $uid);
}
/**
* 将 client_id 与 uid 解除绑定
*
* @param int $client_id
* @param int|string $uid
* @return void
*/
public static function unbindUid($client_id, $uid)
{
static::sendCmdAndMessageToClient($client_id, GatewayProtocol::CMD_UNBIND_UID, '', $uid);
}
/**
* 将 client_id 加入组
*
* @param int $client_id
* @param int|string $group
* @return void
*/
public static function joinGroup($client_id, $group)
{
static::sendCmdAndMessageToClient($client_id, GatewayProtocol::CMD_JOIN_GROUP, '', $group);
}
/**
* 将 client_id 离开组
*
* @param int $client_id
* @param int|string $group
*
* @return void
*/
public static function leaveGroup($client_id, $group)
{
static::sendCmdAndMessageToClient($client_id, GatewayProtocol::CMD_LEAVE_GROUP, '', $group);
}
/**
* 取消分组
*
* @param int|string $group
*
* @return void
*/
public static function ungroup($group)
{
if (!static::isValidGroupId($group)) {
return false;
}
$gateway_data = GatewayProtocol::$empty;
$gateway_data['cmd'] = GatewayProtocol::CMD_UNGROUP;
$gateway_data['ext_data'] = $group;
return static::sendToAllGateway($gateway_data);
}
/**
* 向所有 uid 发送
*
* @param int|string|array $uid
* @param string $message
*
* @return void
*/
public static function sendToUid($uid, $message)
{
$gateway_data = GatewayProtocol::$empty;
$gateway_data['cmd'] = GatewayProtocol::CMD_SEND_TO_UID;
$gateway_data['body'] = $message;
if (!is_array($uid)) {
$uid = array($uid);
}
$gateway_data['ext_data'] = json_encode($uid);
static::sendToAllGateway($gateway_data);
}
/**
* 向 group 发送
*
* @param int|string|array $group 组（不允许是 0 '0' false null array()等为空的值）
* @param string $message 消息
* @param array $exclude_client_id 不给这些client_id发
* @param bool $raw 发送原始数据（即不调用gateway的协议的encode方法）
*
* @return void
*/
public static function sendToGroup($group, $message, $exclude_client_id = null, $raw = false)
{
if (!static::isValidGroupId($group)) {
return false;
}
$gateway_data = GatewayProtocol::$empty;
$gateway_data['cmd'] = GatewayProtocol::CMD_SEND_TO_GROUP;
$gateway_data['body'] = $message;
if ($raw) {
$gateway_data['flag'] |= GatewayProtocol::FLAG_NOT_CALL_ENCODE;
}
if (!is_array($group)) {
$group = array($group);
}
// 分组发送，没有排除的client_id，直接发送
$default_ext_data_buffer = json_encode(array('group' => $group, 'exclude' => null));
if (empty($exclude_client_id)) {
$gateway_data['ext_data'] = $default_ext_data_buffer;
return static::sendToAllGateway($gateway_data);
}
// 分组发送，有排除的client_id，需要将client_id转换成对应gateway进程内的connectionId
if (!is_array($exclude_client_id)) {
$exclude_client_id = array($exclude_client_id);
}
$address_connection_array = static::clientIdArrayToAddressArray($exclude_client_id);
// 如果有businessWorker实例，说明运行在workerman环境中，通过businessWorker中的长连接发送数据
if (static::$businessWorker) {
foreach (static::$businessWorker->gatewayConnections as $address => $gateway_connection) {
$gateway_data['ext_data'] = isset($address_connection_array[$address]) ?
json_encode(array('group' => $group, 'exclude' => $address_connection_array[$address])) :
$default_ext_data_buffer;
/** @var TcpConnection $gateway_connection */
$gateway_connection->send($gateway_data);
}
} // 运行在其它环境中，通过注册中心得到gateway地址
else {
$addresses = static::getAllGatewayAddressesFromRegister();
if (!$addresses) {
throw new Exception('Gateway::getAllGatewayAddressesFromRegister() with registerAddress:' .
static::$registerAddress . ' return ' . var_export($addresses, true));
}
foreach ($addresses as $address) {
$gateway_data['ext_data'] = isset($address_connection_array[$address]) ?
json_encode(array('group' => $group, 'exclude' => $address_connection_array[$address])) :
$default_ext_data_buffer;
static::sendToGateway($address, $gateway_data);
}
}
}
/**
* 更新 session，框架自动调用，开发者不要调用
*
* @param int $client_id
* @param string $session_str
* @return bool
*/
public static function setSocketSession($client_id, $session_str)
{
return static::sendCmdAndMessageToClient($client_id, GatewayProtocol::CMD_SET_SESSION, '', $session_str);
}
/**
* 设置 session，原session值会被覆盖
*
* @param int $client_id
* @param array $session
*
* @return void
*/
public static function setSession($client_id, array $session)
{
if (Context::$client_id === $client_id) {
$_SESSION = $session;
Context::$old_session = $_SESSION;
}
static::setSocketSession($client_id, Context::sessionEncode($session));
}
/**
* 更新 session，实际上是与老的session合并
*
* @param int $client_id
* @param array $session
*
* @return void
*/
public static function updateSession($client_id, array $session)
{
if (Context::$client_id === $client_id) {
$_SESSION = $session + (array)$_SESSION;
Context::$old_session = $_SESSION;
}
static::sendCmdAndMessageToClient($client_id, GatewayProtocol::CMD_UPDATE_SESSION, '', Context::sessionEncode($session));
}
/**
* 获取某个client_id的session
*
* @param int $client_id
* @return mixed false表示出错、null表示用户不存在、array表示具体的session信息
*/
public static function getSession($client_id)
{
$address_data = Context::clientIdToAddress($client_id);
if (!$address_data) {
return false;
}
$address = long2ip($address_data['local_ip']) . ":{$address_data['local_port']}";
if (isset(static::$businessWorker)) {
if (!isset(static::$businessWorker->gatewayConnections[$address])) {
return null;
}
}
$gateway_data = GatewayProtocol::$empty;
$gateway_data['cmd'] = GatewayProtocol::CMD_GET_SESSION_BY_CLIENT_ID;
$gateway_data['connection_id'] = $address_data['connection_id'];
return static::sendAndRecv($address, $gateway_data);
}
/**
* 向某个用户网关发送命令和消息
*
* @param int $client_id
* @param int $cmd
* @param string $message
* @param string $ext_data
* @return boolean
*/
protected static function sendCmdAndMessageToClient($client_id, $cmd, $message, $ext_data = '')
{
// 如果是发给当前用户则直接获取上下文中的地址
if ($client_id === Context::$client_id || $client_id === null) {
$address = long2ip(Context::$local_ip) . ':' . Context::$local_port;
$connection_id = Context::$connection_id;
} else {
$address_data = Context::clientIdToAddress($client_id);
if (!$address_data) {
return false;
}
$address = long2ip($address_data['local_ip']) . ":{$address_data['local_port']}";
$connection_id = $address_data['connection_id'];
}
$gateway_data = GatewayProtocol::$empty;
$gateway_data['cmd'] = $cmd;
$gateway_data['connection_id'] = $connection_id;
$gateway_data['body'] = $message;
if (!empty($ext_data)) {
$gateway_data['ext_data'] = $ext_data;
}
return static::sendToGateway($address, $gateway_data);
}
/**
* 发送数据并返回
*
* @param int $address
* @param mixed $data
* @return bool
* @throws Exception
*/
protected static function sendAndRecv($address, $data)
{
$buffer = GatewayProtocol::encode($data);
$buffer = static::$secretKey ? static::generateAuthBuffer() . $buffer : $buffer;
$client = stream_socket_client("tcp://$address", $errno, $errmsg, static::$connectTimeout);
if (!$client) {
throw new Exception("can not connect to tcp://$address $errmsg");
}
if (strlen($buffer) === stream_socket_sendto($client, $buffer)) {
$timeout = 5;
// 阻塞读
stream_set_blocking($client, 1);
// 1秒超时
stream_set_timeout($client, 1);
$all_buffer = '';
$time_start = microtime(true);
$pack_len = 0;
while (1) {
$buf = stream_socket_recvfrom($client, 655350);
if ($buf !== '' && $buf !== false) {
$all_buffer .= $buf;
} else {
if (feof($client)) {
throw new Exception("connection close tcp://$address");
} elseif (microtime(true) - $time_start > $timeout) {
break;
}
continue;
}
$recv_len = strlen($all_buffer);
if (!$pack_len && $recv_len >= 4) {
$pack_len = current(unpack('N', $all_buffer));
}
// 回复的数据都是以\n结尾
if (($pack_len && $recv_len >= $pack_len + 4) || microtime(true) - $time_start > $timeout) {
break;
}
}
// 返回结果
return unserialize(substr($all_buffer, 4));
} else {
throw new Exception("sendAndRecv($address, \$bufer) fail ! Can not send data!", 502);
}
}
/**
* 发送数据到网关
*
* @param string $address
* @param array $gateway_data
* @return bool
*/
protected static function sendToGateway($address, $gateway_data)
{
return static::sendBufferToGateway($address, GatewayProtocol::encode($gateway_data));
}
/**
* 发送buffer数据到网关
* @param string $address
* @param string $gateway_buffer
* @return bool
*/
protected static function sendBufferToGateway($address, $gateway_buffer)
{
// 有$businessWorker说明是workerman环境，使用$businessWorker发送数据
if (static::$businessWorker) {
if (!isset(static::$businessWorker->gatewayConnections[$address])) {
return false;
}
return static::$businessWorker->gatewayConnections[$address]->send($gateway_buffer, true);
}
// 非workerman环境
$gateway_buffer = static::$secretKey ? static::generateAuthBuffer() . $gateway_buffer : $gateway_buffer;
$flag = static::$persistentConnection ? STREAM_CLIENT_PERSISTENT | STREAM_CLIENT_CONNECT : STREAM_CLIENT_CONNECT;
$client = stream_socket_client("tcp://$address", $errno, $errmsg, static::$connectTimeout, $flag);
return strlen($gateway_buffer) == stream_socket_sendto($client, $gateway_buffer);
}
/**
* 向所有 gateway 发送数据
*
* @param string $gateway_data
* @throws Exception
*
* @return void
*/
protected static function sendToAllGateway($gateway_data)
{
$buffer = GatewayProtocol::encode($gateway_data);
// 如果有businessWorker实例，说明运行在workerman环境中，通过businessWorker中的长连接发送数据
if (static::$businessWorker) {
foreach (static::$businessWorker->gatewayConnections as $gateway_connection) {
/** @var TcpConnection $gateway_connection */
$gateway_connection->send($buffer, true);
}
} // 运行在其它环境中，通过注册中心得到gateway地址
else {
$all_addresses = static::getAllGatewayAddressesFromRegister();
if (!$all_addresses) {
throw new Exception('Gateway::getAllGatewayAddressesFromRegister() with registerAddress:' .
static::$registerAddress . ' return ' . var_export($all_addresses, true));
}
foreach ($all_addresses as $address) {
static::sendBufferToGateway($address, $buffer);
}
}
}
/**
* 踢掉某个网关的 socket
*
* @param string $address
* @param int $connection_id
* @return bool
*/
protected static function kickAddress($address, $connection_id, $message)
{
$gateway_data = GatewayProtocol::$empty;
$gateway_data['cmd'] = GatewayProtocol::CMD_KICK;
$gateway_data['connection_id'] = $connection_id;
$gateway_data['body'] = $message;
return static::sendToGateway($address, $gateway_data);
}
/**
* 销毁某个网关的 socket
*
* @param string $address
* @param int $connection_id
* @return bool
*/
protected static function destroyAddress($address, $connection_id)
{
$gateway_data = GatewayProtocol::$empty;
$gateway_data['cmd'] = GatewayProtocol::CMD_DESTROY;
$gateway_data['connection_id'] = $connection_id;
return static::sendToGateway($address, $gateway_data);
}
/**
* 将clientid数组转换成address数组
*
* @param array $client_id_array
* @return array
*/
protected static function clientIdArrayToAddressArray(array $client_id_array)
{
$address_connection_array = array();
foreach ($client_id_array as $client_id) {
$address_data = Context::clientIdToAddress($client_id);
if ($address_data) {
$address = long2ip($address_data['local_ip']) .
":{$address_data['local_port']}";
$address_connection_array[$address][$address_data['connection_id']] = $address_data['connection_id'];
}
}
return $address_connection_array;
}
/**
* 设置 gateway 实例
*
* @param \GatewayWorker\BusinessWorker $business_worker_instance
*/
public static function setBusinessWorker($business_worker_instance)
{
static::$businessWorker = $business_worker_instance;
}
/**
* 获取通过注册中心获取所有 gateway 通讯地址
*
* @return array
* @throws Exception
*/
protected static function getAllGatewayAddressesFromRegister()
{
static $addresses_cache, $last_update, $last_register_address;
$time_now = time();
$expiration_time = 1;
if (empty($addresses_cache) || $time_now - $last_update > $expiration_time || $last_register_address !== static::$registerAddress) {
$client = stream_socket_client('tcp://' . static::$registerAddress, $errno, $errmsg, static::$connectTimeout);
if (!$client) {
throw new Exception('Can not connect to tcp://' . static::$registerAddress . ' ' . $errmsg);
}
fwrite($client, '{"event":"worker_connect","secret_key":"' . static::$secretKey . '"}' . "\n");
stream_set_timeout($client, 5);
$ret = fgets($client, 655350);
if (!$ret || !$data = json_decode(trim($ret), true)) {
throw new Exception('getAllGatewayAddressesFromRegister fail. tcp://' .
static::$registerAddress . ' return ' . var_export($ret, true));
}
$last_update = $time_now;
$last_register_address = static::$registerAddress;
$addresses_cache = $data['addresses'];
}
return $addresses_cache;
}
/**
* 检查群组id是否合法
*
* @param $group
* @return bool
*/
protected static function isValidGroupId($group)
{
if (empty($group)) {
echo new \Exception('group(' . var_export($group, true) . ') empty');
return false;
}
return true;
}
}
/**
* 上下文 包含当前用户uid， 内部通信local_ip local_port socket_id ，以及客户端client_ip client_port
*/
class Context
{
/**
* 内部通讯id
* @var string
*/
public static $local_ip;
/**
* 内部通讯端口
* @var int
*/
public static $local_port;
/**
* 客户端ip
* @var string
*/
public static $client_ip;
/**
* 客户端端口
* @var int
*/
public static $client_port;
/**
* client_id
* @var string
*/
public static $client_id;
/**
* 连接connection->id
* @var int
*/
public static $connection_id;
/**
* 旧的session
*
* @var string
*/
public static $old_session;
/**
* 编码session
* @param mixed $session_data
* @return string
*/
public static function sessionEncode($session_data = '')
{
if ($session_data !== '') {
return serialize($session_data);
}
return '';
}
/**
* 解码session
* @param string $session_buffer
* @return mixed
*/
public static function sessionDecode($session_buffer)
{
return unserialize($session_buffer);
}
/**
* 清除上下文
* @return void
*/
public static function clear()
{
static::$local_ip = static::$local_port = static::$client_ip = static::$client_port =
static::$client_id = static::$connection_id = static::$old_session = null;
}
/**
* 通讯地址到client_id的转换
* @return string
*/
public static function addressToClientId($local_ip, $local_port, $connection_id)
{
return bin2hex(pack('NnN', $local_ip, $local_port, $connection_id));
}
/**
* client_id到通讯地址的转换
* @return array
*/
public static function clientIdToAddress($client_id)
{
if (strlen($client_id) !== 20) {
throw new \Exception("client_id $client_id is invalid");
}
return unpack('Nlocal_ip/nlocal_port/Nconnection_id', pack('H*', $client_id));
}
}
/**
* Gateway 与 Worker 间通讯的二进制协议
*
* struct GatewayProtocol
* {
* unsigned int pack_len,
* unsigned char cmd,//命令字
* unsigned int local_ip,
* unsigned short local_port,
* unsigned int client_ip,
* unsigned short client_port,
* unsigned int connection_id,
* unsigned char flag,
* unsigned short gateway_port,
* unsigned int ext_len,
* char[ext_len] ext_data,
* char[pack_length-HEAD_LEN] body//包体
* }
* NCNnNnNCnN
*/
class GatewayProtocol
{
// 发给worker，gateway有一个新的连接
const CMD_ON_CONNECT = 1;
// 发给worker的，客户端有消息
const CMD_ON_MESSAGE = 3;
// 发给worker上的关闭链接事件
const CMD_ON_CLOSE = 4;
// 发给gateway的向单个用户发送数据
const CMD_SEND_TO_ONE = 5;
// 发给gateway的向所有用户发送数据
const CMD_SEND_TO_ALL = 6;
// 发给gateway的踢出用户
// 1、如果有待发消息，将在发送完后立即销毁用户连接
// 2、如果无待发消息，将立即销毁用户连接
const CMD_KICK = 7;
// 发给gateway的立即销毁用户连接
const CMD_DESTROY = 8;
// 发给gateway，通知用户session更新
const CMD_UPDATE_SESSION = 9;
// 获取在线状态
const CMD_GET_ALL_CLIENT_SESSIONS = 10;
// 判断是否在线
const CMD_IS_ONLINE = 11;
// client_id绑定到uid
const CMD_BIND_UID = 12;
// 解绑
const CMD_UNBIND_UID = 13;
// 向uid发送数据
const CMD_SEND_TO_UID = 14;
// 根据uid获取绑定的clientid
const CMD_GET_CLIENT_ID_BY_UID = 15;
// 加入组
const CMD_JOIN_GROUP = 20;
// 离开组
const CMD_LEAVE_GROUP = 21;
// 向组成员发消息
const CMD_SEND_TO_GROUP = 22;
// 获取组成员
const CMD_GET_CLINET_SESSUONS_BY_GROUP = 23;
// 获取组在线连接数
const CMD_GET_CLIENT_COUNT_BY_GROUP = 24;
// 按照条件查找
const CMD_SELECT = 25;
// 获取在线的群组ID
const CMD_GET_GROUP_ID_LIST = 26;
// 取消分组
const CMD_UNGROUP = 27;
// worker连接gateway事件
const CMD_WORKER_CONNECT = 200;
// 心跳
const CMD_PING = 201;
// GatewayClient连接gateway事件
const CMD_GATEWAY_CLIENT_CONNECT = 202;
// 根据client_id获取session
const CMD_GET_SESSION_BY_CLIENT_ID = 203;
// 发给gateway，覆盖session
const CMD_SET_SESSION = 204;
// 当websocket握手时触发，只有websocket协议支持此命令字
const CMD_ON_WEBSOCKET_CONNECT = 205;
// 包体是标量
const FLAG_BODY_IS_SCALAR = 0x01;
// 通知gateway在send时不调用协议encode方法，在广播组播时提升性能
const FLAG_NOT_CALL_ENCODE = 0x02;
/**
* 包头长度
*
* @var int
*/
const HEAD_LEN = 28;
public static $empty = array(
'cmd' => 0,
'local_ip' => 0,
'local_port' => 0,
'client_ip' => 0,
'client_port' => 0,
'connection_id' => 0,
'flag' => 0,
'gateway_port' => 0,
'ext_data' => '',
'body' => '',
);
/**
* 返回包长度
*
* @param string $buffer
* @return int return current package length
*/
public static function input($buffer)
{
if (strlen($buffer) < self::HEAD_LEN) {
return 0;
}
$data = unpack("Npack_len", $buffer);
return $data['pack_len'];
}
/**
* 获取整个包的 buffer
*
* @param mixed $data
* @return string
*/
public static function encode($data)
{
$flag = (int)is_scalar($data['body']);
if (!$flag) {
$data['body'] = serialize($data['body']);
}
$data['flag'] |= $flag;
$ext_len = strlen($data['ext_data']);
$package_len = self::HEAD_LEN + $ext_len + strlen($data['body']);
return pack("NCNnNnNCnN", $package_len,
$data['cmd'], $data['local_ip'],
$data['local_port'], $data['client_ip'],
$data['client_port'], $data['connection_id'],
$data['flag'], $data['gateway_port'],
$ext_len) . $data['ext_data'] . $data['body'];
}
/**
* 从二进制数据转换为数组
*
* @param string $buffer
* @return array
*/
public static function decode($buffer)
{
$data = unpack("Npack_len/Ccmd/Nlocal_ip/nlocal_port/Nclient_ip/nclient_port/Nconnection_id/Cflag/ngateway_port/Next_len",
$buffer);
if ($data['ext_len'] > 0) {
$data['ext_data'] = substr($buffer, self::HEAD_LEN, $data['ext_len']);
if ($data['flag'] & self::FLAG_BODY_IS_SCALAR) {
$data['body'] = substr($buffer, self::HEAD_LEN + $data['ext_len']);
} else {
$data['body'] = unserialize(substr($buffer, self::HEAD_LEN + $data['ext_len']));
}
} else {
$data['ext_data'] = '';
if ($data['flag'] & self::FLAG_BODY_IS_SCALAR) {
$data['body'] = substr($buffer, self::HEAD_LEN);
} else {
$data['body'] = unserialize(substr($buffer, self::HEAD_LEN));
}
}
return $data;
}
}
Lib/aliyun/Client.php 0 → 100644
<?php
/**
* Created by PhpStorm.
* User: banice
* Date: 2018/7/29
* Time: 下午3:54
*/
namespace Lib\aliyun;
use Illuminate\Console\Scheduling\Event;
use Illuminate\Support\Facades\Log;
use Lib\aliyun\api\BaseApi;
use Lib\aliyun\sign\Sign;
use function MongoDB\BSON\toJSON;
use Psr\Http\Message\ResponseInterface;
class Client
{
/**
* @var BaseApi
*/
private $api;
/**
* @var \GuzzleHttp\Client
*/
private $client;
/**
* @var ResponseInterface
*/
private $response;
/**
* @var bool
*/
private $result = false;
/**
* @var string
*
*/
private $errorMessage = '';
/**
* @var string
*/
private $requestId;
/**
* @var array
*/
private $responseData;
/**
* aliyun iot uri
*/
// const URI = 'https://iot.aliyuncs.com/';
const URI = 'https://iot.cn-shanghai.aliyuncs.com/';
public function __construct()
{
$this->client = new \GuzzleHttp\Client();
}
/**
* @param string $method
* @return bool
*/
public function request($method = 'GET')
{
$sign = new Sign($this->api);
$signature = $sign->sign($method);
if ($this->api instanceof BaseApi) {
$this->api->setSignature($signature);
}
$request = $this->api->getRequest();
$request['Signature'] = $signature;
$str = '';
foreach ($request as $key => $value) {
$str .= '&' . $key . '=' . urlencode($value);
}
$str = trim($str, '&');
$this->response = $this->client->get(self::URI . '?' . $str);
$data = json_decode($this->response->getBody(), true);
Log::debug($data);
if ($this->response->getStatusCode() === 200) {
if ($data['Success'] === true) {
$this->result = true;
$this->requestId = $data['RequestId'];
$this->responseData = $data;
if (isset($data['Data'])) {
$this->api->parseResponse($data);
}
} else {
$this->errorMessage = $data['ErrorMessage'];
$this->result = false;
}
}
return $this->result;
}
/**
* @return BaseApi
*/
public function getApi(): BaseApi
{
return $this->api;
}
/**
* @param BaseApi $api
*/
public function setApi(BaseApi $api): void
{
$this->api = $api;
}
/**
* @return \GuzzleHttp\Client
*/
public function getClient(): \GuzzleHttp\Client
{
return $this->client;
}
/**
* @param \GuzzleHttp\Client $client
*/
public function setClient(\GuzzleHttp\Client $client): void
{
$this->client = $client;
}
/**
* @return ResponseInterface
*/
public function getResponse(): ResponseInterface
{
return $this->response;
}
/**
* @return bool
*/
public function isResult(): bool
{
return $this->result;
}
/**
* @param bool $result
*/
public function setResult(bool $result): void
{
$this->result = $result;
}
/**
* @return string
*/
public function getErrorMessage(): string
{
return $this->errorMessage;
}
/**
* @param string $errorMessage
*/
public function setErrorMessage(string $errorMessage): void
{
$this->errorMessage = $errorMessage;
}
/**
* @return string
*/
public function getRequestId(): string
{
return $this->requestId;
}
/**
* @param string $requestId
*/
public function setRequestId(string $requestId): void
{
$this->requestId = $requestId;
}
/**
* @return array
*/
public function getResponseData(): array
{
return $this->responseData;
}
}
\ No newline at end of file
Lib/aliyun/Config.php 0 → 100644
<?php
/**
* Created by PhpStorm.
* User: banice
* Date: 2018/7/29
* Time: 下午3:51
*/
namespace Lib\aliyun;
class Config
{
const FORMAT = 'json';
const Version = '2018-01-20';
const AccessKeyId = 'LTAItZVbkVaVXifu';
const SignatureMethod = 'HMAC-SHA1';
const SignatureVersion = '1.0';
const RegionId = 'cn-shanghai';
// LTAIRUkuhDA4poTj ysh accessId
//1WE7UvMuA0QZIwl8JjekTXB9ccxkpy ysh secret
const ACCESS_SECRET = 'Irko4313cUEbb1RYXGWEz6s6VgNETG';
// const ACCESS_SECRET = 'Irko4313cUEbb1RYXGWEz6s6VgNETG';
const ACCESS_KEY = 'LTAItZVbkVaVXifu';
// const ACCESS_KEY='LTAIRUkuhDA4poTj';
}
\ No newline at end of file
Lib/aliyun/api/BaseApi.php 0 → 100644
<?php
/**
* Created by PhpStorm.
* User: banice
* Date: 2018/7/29
* Time: 下午3:56
*/
namespace Lib\aliyun\api;
use Lib\aliyun\Config;
abstract class BaseApi
{
/**
* @var string
*/
protected $action = '';
/**
* @var string
*/
protected $format = Config::FORMAT;
/**
* @var string
*/
protected $version = Config::Version;
/**
* @var string
*/
protected $accessKeyId = Config::AccessKeyId;
/**
* @var string
*/
protected $signatureMethod = Config::SignatureMethod;
/**
* @var string
*/
protected $signatureVersion = Config::SignatureVersion;
/**
* @var string
*/
protected $regionId = Config::RegionId;
/**
* @var false|string
*/
protected $timestamp = '';
/**
* @var string
*/
protected $signatureNonce = '';
/**
* @var string
*/
protected $signature = '';
/**
* @var array
*/
protected $request = [];
/**
* @var string
*/
protected $errorMessage;
/**
* @return array
*/
abstract public function getRequest(): array;
/**
* @param array $data
*/
abstract public function parseResponse(array $data): void;
/**
* BaseApi constructor.
*/
public function __construct()
{
$this->timestamp = date('Y-m-d\TH:i:s\Z', time() - 60 * 60 * 8);
$this->signatureNonce = md5(uniqid(mt_rand(), true));
}
/**
* @return array
*/
protected function getCommonRequest()
{
return [
'Action' => $this->action,
'Format' => $this->format,
'Version' => $this->version,
'AccessKeyId' => $this->accessKeyId,
'SignatureMethod' => $this->signatureMethod,
'Timestamp' => $this->timestamp,
'SignatureVersion' => $this->signatureVersion,
'SignatureNonce' => $this->signatureNonce,
'RegionId' => $this->regionId,
];
}
/**
* @return string
*/
public function getFormat(): string
{
return $this->format;
}
/**
* @param string $format
*/
public function setFormat(string $format): void
{
$this->format = $format;
}
/**
* @return string
*/
public function getVersion(): string
{
return $this->version;
}
/**
* @param string $version
*/
public function setVersion(string $version): void
{
$this->version = $version;
}
/**
* @return string
*/
public function getAccessKeyId(): string
{
return $this->accessKeyId;
}
/**
* @param string $accessKeyId
*/
public function setAccessKeyId(string $accessKeyId): void
{
$this->accessKeyId = $accessKeyId;
}
/**
* @return string
*/
public function getSignatureMethod(): string
{
return $this->signatureMethod;
}
/**
* @param string $signatureMethod
*/
public function setSignatureMethod(string $signatureMethod): void
{
$this->signatureMethod = $signatureMethod;
}
/**
* @return string
*/
public function getSignatureVersion(): string
{
return $this->signatureVersion;
}
/**
* @param string $signatureVersion
*/
public function setSignatureVersion(string $signatureVersion): void
{
$this->signatureVersion = $signatureVersion;
}
/**
* @return string
*/
public function getRegionId(): string
{
return $this->regionId;
}
/**
* @param string $regionId
*/
public function setRegionId(string $regionId): void
{
$this->regionId = $regionId;
}
/**
* @return false|string
*/
public function getTimestamp()
{
return $this->timestamp;
}
/**
* @param false|string $timestamp
*/
public function setTimestamp($timestamp): void
{
$this->timestamp = $timestamp;
}
/**
* @return string
*/
public function getSignatureNonce(): string
{
return $this->signatureNonce;
}
/**
* @param string $signatureNonce
*/
public function setSignatureNonce(string $signatureNonce): void
{
$this->signatureNonce = $signatureNonce;
}
/**
* @return string
*/
public function getSignature(): string
{
return $this->signature;
}
/**
* @param string $signature
*/
public function setSignature(string $signature): void
{
$this->signature = $signature;
}
/**
* @return string
*/
public function getAction(): string
{
return $this->action;
}
/**
* @param string $action
*/
public function setAction(string $action): void
{
$this->action = $action;
}
/**
* @return string
*/
public function getErrorMessage(): string
{
return $this->errorMessage;
}
/**
* @param string $errorMessage
*/
public function setErrorMessage(string $errorMessage): void
{
$this->errorMessage = $errorMessage;
}
/**
* @param array $request
*/
public function setRequest(array $request): void
{
$this->request = $request;
}
}
\ No newline at end of file
Lib/aliyun/api/IApi.php 0 → 100644
<?php
/**
* Created by PhpStorm.
* User: banice
* Date: 2018/7/29
* Time: 下午3:55
*/
namespace Lib\aliyun\api;
interface IApi
{
public function getRequest(): array;
public function parseResponse():void ;
}
\ No newline at end of file
Lib/aliyun/api/PublishToTopic.php 0 → 100644
<?php
/**
* Created by PhpStorm.
* User: banice
* Date: 2018/7/29
* Time: 下午3:54
*/
namespace Lib\aliyun\api;
class PublishToTopic extends BaseApi
{
protected $action = 'Pub';
/**
* @var string
*/
private $productKey = '';
/**
* @var string
*/
private $messageContent = '';
/**
* @var string
*/
private $topicFullName = '';
/**
* @var string
*/
private $messageId;
/**
* @var int
*/
private $qos = 0;
public function __construct()
{
parent::__construct();
}
/**
* @return array
* @throws \Exception
*/
public function getRequest(): array
{
$parameters = get_object_vars($this);
// foreach ($parameters as $parameter => $value) {
// if ($parameter != 'signature') {
//
// }
// }
$this->request = [
'Action' => $this->action,
'Format' => $this->format,
'Version' => $this->version,
'AccessKeyId' => $this->accessKeyId,
'SignatureMethod' => $this->signatureMethod,
'Timestamp' => $this->timestamp,
'SignatureVersion' => $this->signatureVersion,
'SignatureNonce' => $this->signatureNonce,
'RegionId' => $this->regionId,
'ProductKey' => $this->productKey,
'MessageContent' => $this->messageContent,
'TopicFullName' => $this->topicFullName,
'Qos' => $this->qos,
];
ksort($this->request);
return $this->request;
}
public function parseResponse(array $data): void
{
if ($data['Success'] === true) {
$this->messageId = $data['MessageId'];
}
}
/**
* @return string
*/
public function getProductKey(): string
{
return $this->productKey;
}
/**
* @param string $productKey
*/
public function setProductKey(string $productKey): void
{
$this->productKey = $productKey;
}
/**
* @return string
*/
public function getMessageContent(): string
{
return $this->messageContent;
}
/**
* @param string $messageContent
*/
public function setMessageContent(string $messageContent): void
{
$messageContent = base64_encode($messageContent);
$this->messageContent = $messageContent;
}
/**
* @return string
*/
public function getTopicFullName(): string
{
return $this->topicFullName;
}
/**
* @param string $topicFullName
*/
public function setTopicFullName(string $topicFullName): void
{
$this->topicFullName = $topicFullName;
}
/**
* @return int
*/
public function getQos(): int
{
return $this->qos;
}
/**
* @param int $qos
*/
public function setQos(int $qos): void
{
$this->qos = $qos;
}
/**
* @return string
*/
public function getMessageId(): string
{
return $this->messageId;
}
/**
* @param string $messageId
*/
public function setMessageId(string $messageId): void
{
$this->messageId = $messageId;
}
}
\ No newline at end of file
Lib/aliyun/api/device/GetDevicesStatus.php 0 → 100644
<?php
/**
* Created by PhpStorm.
* User: banice
* Date: 2018/8/1
* Time: 上午10:28
*/
namespace Lib\aliyun\api\device;
use Lib\aliyun\api\BaseApi;
class GetDevicesStatus extends BaseApi
{
/**
* @var string
*/
protected $action = 'GetDeviceStatus';
/**
* @var string
*/
private $iotId;
/**
* @var string
*/
private $productKey;
/**
* @var string
*/
private $deviceName;
/**
* @var string
*/
private $status;
/**
* @return array
*/
public function getRequest(): array
{
if (isset($this->iotId)) {
$tmp = [
'IotId' => $this->iotId,
];
} else {
$tmp = [
'ProductKey' => $this->productKey,
'DeviceName' => $this->deviceName,
];
}
return $tmp + $this->getCommonRequest();
}
public function parseResponse(array $data): void
{
if ($data['Success'] === true) {
switch ($data['Data']['Status']) {
case 'ONLINE':
$this->status = 1;
break;
case 'OFFLINE':
$this->status = 0;
break;
case 'UNACTIVE':
$this->status = 2;
break;
case 'DISABLE':
$this->status = 3;
break;
default:
break;
}
}
}
/**
* @return string
*/
public function getAction(): string
{
return $this->action;
}
/**
* @param string $action
*/
public function setAction(string $action): void
{
$this->action = $action;
}
/**
* @return string
*/
public function getIotId(): string
{
return $this->iotId;
}
/**
* @param string $iotId
*/
public function setIotId(string $iotId): void
{
$this->iotId = $iotId;
}
/**
* @return string
*/
public function getProductKey(): string
{
return $this->productKey;
}
/**
* @param string $productKey
*/
public function setProductKey(string $productKey): void
{
$this->productKey = $productKey;
}
/**
* @return string
*/
public function getDeviceName(): string
{
return $this->deviceName;
}
/**
* @param string $deviceName
*/
public function setDeviceName(string $deviceName): void
{
$this->deviceName = $deviceName;
}
/**
* @return string
*/
public function getStatus(): string
{
return $this->status;
}
/**
* @param string $status
*/
public function setStatus(string $status): void
{
$this->status = $status;
}
}
\ No newline at end of file
Lib/aliyun/api/device/QueryDevice.php 0 → 100644
<?php
/**
* Created by PhpStorm.
* User: banice
* Date: 2018/8/7
* Time: 上午10:05
*/
namespace Lib\aliyun\api\device;
use Lib\aliyun\api\BaseApi;
class QueryDevice extends BaseApi
{
/**
* @var string
*/
protected $action = 'QueryDevice';
/**
* @var string
*/
private $productKey;
/**
* @var int
*/
private $pageSize = 10;
/**
* @var int
*/
private $currentPage = 1;
public function getRequest(): array
{
return $this->getCommonRequest() + [
'ProductKey' => $this->productKey,
'PageSize' => $this->pageSize,
'CurrentPage' => $this->currentPage,
];
// TODO: Implement getRequest() method.
}
public function parseResponse(array $data): void
{
}
/**
* @return string
*/
public function getAction(): string
{
return $this->action;
}
/**
* @param string $action
*/
public function setAction(string $action): void
{
$this->action = $action;
}
/**
* @return string
*/
public function getProductKey(): string
{
return $this->productKey;
}
/**
* @param string $productKey
*/
public function setProductKey(string $productKey): void
{
$this->productKey = $productKey;
}
/**
* @return int
*/
public function getPageSize(): int
{
return $this->pageSize;
}
/**
* @param int $pageSize
*/
public function setPageSize(int $pageSize): void
{
$this->pageSize = $pageSize;
}
/**
* @return int
*/
public function getCurrentPage(): int
{
return $this->currentPage;
}
/**
* @param int $currentPage
*/
public function setCurrentPage(int $currentPage): void
{
$this->currentPage = $currentPage;
}
}
\ No newline at end of file
Lib/aliyun/api/device/QueryDeviceDetail.php 0 → 100644
<?php
/**
* Created by PhpStorm.
* User: banice
* Date: 2018/8/7
* Time: 上午9:52
*/
namespace Lib\aliyun\api\device;
use Lib\aliyun\api\BaseApi;
class QueryDeviceDetail extends BaseApi
{
/**
* @var string
*/
protected $action = 'QueryDeviceDetail';
/**
* @var string
*/
private $iotId;
/**
* @var string
*/
private $productKey;
/**
* @var string
*/
private $deviceName;
/**
* @var string
*/
private $productName;
/**
* @var string
*/
private $deviceSecret;
/**
* @var string
*/
private $gmtGreate;
/**
* @var string
*/
private $gmtActive;
/**
* @var
*/
private $gmtOnline;
/**
* @var string
*/
private $status;
public function getRequest(): array
{
return $this->getCommonRequest() + [
'IotId' => $this->iotId,
'ProductKey' => $this->productKey,
'DeviceName' => $this->deviceName,
];
}
public function parseResponse(array $data): void
{
$data = $data['Data'];
$this->productName = $data['ProductKey'];
$this->deviceSecret = $data['DeviceSecret'];
$this->iotId = $data['IotId'];
$this->gmtGreate = $data['GmtGreate'];
$this->gmtActive = $data['GmtActive'];
$this->gmtOnline = $data['GmtOnline'];
$this->status = $data['Status'];
}
/**
* @return string
*/
public function getAction(): string
{
return $this->action;
}
/**
* @param string $action
*/
public function setAction(string $action): void
{
$this->action = $action;
}
/**
* @return string
*/
public function getIotId(): string
{
return $this->iotId;
}
/**
* @param string $iotId
*/
public function setIotId(string $iotId): void
{
$this->iotId = $iotId;
}
/**
* @return string
*/
public function getProductKey(): string
{
return $this->productKey;
}
/**
* @param string $productKey
*/
public function setProductKey(string $productKey): void
{
$this->productKey = $productKey;
}
/**
* @return string
*/
public function getDeviceName(): string
{
return $this->deviceName;
}
/**
* @param string $deviceName
*/
public function setDeviceName(string $deviceName): void
{
$this->deviceName = $deviceName;
}
/**
* @return string
*/
public function getProductName(): string
{
return $this->productName;
}
/**
* @param string $productName
*/
public function setProductName(string $productName): void
{
$this->productName = $productName;
}
/**
* @return string
*/
public function getDeviceSecret(): string
{
return $this->deviceSecret;
}
/**
* @param string $deviceSecret
*/
public function setDeviceSecret(string $deviceSecret): void
{
$this->deviceSecret = $deviceSecret;
}
/**
* @return string
*/
public function getGmtGreate(): string
{
return $this->gmtGreate;
}
/**
* @param string $gmtGreate
*/
public function setGmtGreate(string $gmtGreate): void
{
$this->gmtGreate = $gmtGreate;
}
/**
* @return string
*/
public function getGmtActive(): string
{
return $this->gmtActive;
}
/**
* @param string $gmtActive
*/
public function setGmtActive(string $gmtActive): void
{
$this->gmtActive = $gmtActive;
}
/**
* @return mixed
*/
public function getGmtOnline()
{
return $this->gmtOnline;
}
/**
* @param mixed $gmtOnline
*/
public function setGmtOnline($gmtOnline): void
{
$this->gmtOnline = $gmtOnline;
}
/**
* @return string
*/
public function getStatus(): string
{
return $this->status;
}
/**
* @param string $status
*/
public function setStatus(string $status): void
{
$this->status = $status;
}
}
Lib/aliyun/api/device/RegisterDevice.php 0 → 100644
<?php
/**
* Created by PhpStorm.
* User: banice
* Date: 2018/8/7
* Time: 上午9:36
*/
namespace Lib\aliyun\api\device;
use Lib\aliyun\api\BaseApi;
class RegisterDevice extends BaseApi
{
/**
* @var string
*/
protected $action = 'RegisterDevice';
/**
* @var string
*/
private $productKey;
/**
* @var string
*/
private $deviceName;
/**
* @var array
*/
private $deviceData;
/**
* @var string
*/
private $deviceSecret;
/**
* @var string
*/
private $deviceIotId;
/**
* @return array
*/
public function getRequest(): array
{
return $this->getCommonRequest() + ['ProductKey' => $this->productKey, 'DeviceName' => $this->deviceName];
}
/**
* @param array $data
*/
public function parseResponse(array $data): void
{
$this->deviceData = $data['Data'];
$this->deviceSecret = $this->deviceData['DeviceSecret'];
$this->deviceIotId = $this->deviceData['IotId'];
}
/**
* @return string
*/
public function getAction(): string
{
return $this->action;
}
/**
* @param string $action
*/
public function setAction(string $action): void
{
$this->action = $action;
}
/**
* @return string
*/
public function getProductKey(): string
{
return $this->productKey;
}
/**
* @param string $productKey
*/
public function setProductKey(string $productKey): void
{
$this->productKey = $productKey;
}
/**
* @return string
*/
public function getDeviceName(): string
{
return $this->deviceName;
}
/**
* @param string $deviceName
*/
public function setDeviceName(string $deviceName): void
{
$this->deviceName = $deviceName;
}
/**
* @return array
*/
public function getDeviceData(): array
{
return $this->deviceData;
}
/**
* @param array $deviceData
*/
public function setDeviceData(array $deviceData): void
{
$this->deviceData = $deviceData;
}
/**
* @return string
*/
public function getDeviceSecret(): string
{
return $this->deviceSecret;
}
/**
* @param string $deviceSecret
*/
public function setDeviceSecret(string $deviceSecret): void
{
$this->deviceSecret = $deviceSecret;
}
/**
* @return string
*/
public function getDeviceIotId(): string
{
return $this->deviceIotId;
}
/**
* @param string $deviceIotId
*/
public function setDeviceIotId(string $deviceIotId): void
{
$this->deviceIotId = $deviceIotId;
}
}
\ No newline at end of file
Lib/aliyun/api/product/CreateProduct.php 0 → 100644
<?php
/**
* Created by PhpStorm.
* User: banice
* Date: 2018/8/7
* Time: 下午3:45
*/
namespace Lib\aliyun\api\product;
use Lib\aliyun\api\BaseApi;
/**
* Class CreateProduct
* @package Lib\aliyun\api\product
*/
class CreateProduct extends BaseApi
{
/**
* @var string
*/
protected $action = 'CreateProduct';
/**
* @var string
*/
private $name;
/**
* @var int
*/
private $nodeType;
/**
* @var int
*/
private $catId;
/**
* @var string
*/
private $desc;
/**
* @var string
*/
private $productName;
/**
* @var string
*/
private $productKey;
/**
* @var string
*/
private $productDesc;
/**
* @var string
*/
private $createUserId;
/**
* @var string
*/
private $fromSource;
public function getRequest(): array
{
$return = [
'Name' => $this->name,
'NodeType' => $this->nodeType,
'CatId' => $this->catId,
'Desc' => $this->desc,
];
$return = array_filter($return, function ($value) {
return isset($value);
});
return $this->getCommonRequest() + $return;
}
public function parseResponse(array $data): void
{
$data = $data['ProductInfo'];
$this->productKey = $data['ProductKey'];
$this->productDesc = $data['ProductDesc'];
$this->fromSource = $data['FromSource'];
}
/**
* @return string
*/
public function getAction(): string
{
return $this->action;
}
/**
* @param string $action
*/
public function setAction(string $action): void
{
$this->action = $action;
}
/**
* @return string
*/
public function getName(): string
{
return $this->name;
}
/**
* @param string $name
*/
public function setName(string $name): void
{
$this->name = $name;
}
/**
* @return int
*/
public function getNodeType(): int
{
return $this->nodeType;
}
/**
* @param int $nodeType
*/
public function setNodeType(int $nodeType): void
{
$this->nodeType = $nodeType;
}
/**
* @return int
*/
public function getCatId(): int
{
return $this->catId;
}
/**
* @param int $catId
*/
public function setCatId(int $catId): void
{
$this->catId = $catId;
}
/**
* @return string
*/
public function getDesc(): string
{
return $this->desc;
}
/**
* @param string $desc
*/
public function setDesc(string $desc): void
{
$this->desc = $desc;
}
/**
* @return string
*/
public function getProductName(): string
{
return $this->productName;
}
/**
* @param string $productName
*/
public function setProductName(string $productName): void
{
$this->productName = $productName;
}
/**
* @return string
*/
public function getProductKey(): string
{
return $this->productKey;
}
/**
* @param string $productKey
*/
public function setProductKey(string $productKey): void
{
$this->productKey = $productKey;
}
/**
* @return string
*/
public function getProductDesc(): string
{
return $this->productDesc;
}
/**
* @param string $productDesc
*/
public function setProductDesc(string $productDesc): void
{
$this->productDesc = $productDesc;
}
/**
* @return string
*/
public function getCreateUserId(): string
{
return $this->createUserId;
}
/**
* @param string $createUserId
*/
public function setCreateUserId(string $createUserId): void
{
$this->createUserId = $createUserId;
}
/**
* @return string
*/
public function getFromSource(): string
{
return $this->fromSource;
}
/**
* @param string $fromSource
*/
public function setFromSource(string $fromSource): void
{
$this->fromSource = $fromSource;
}
}
\ No newline at end of file
Lib/aliyun/api/product/QueryProduct.php 0 → 100644
<?php
/**
* Created by PhpStorm.
* User: banice
* Date: 2018/8/7
* Time: 下午3:53
*/
namespace Lib\aliyun\api\product;
class QueryProduct
{
}
\ No newline at end of file
Lib/aliyun/sign/Sign.php 0 → 100644
<?php
/**
* Created by PhpStorm.
* User: banice
* Date: 2018/7/30
* Time: 上午9:56
*/
namespace Lib\aliyun\sign;
use Illuminate\Support\Facades\Log;
use Lib\aliyun\api\BaseApi;
use Lib\aliyun\Config;
class Sign
{
/**
* @var BaseApi
*/
private $api;
/**
* @var string
*/
private $sign;
public function __construct(BaseApi $api)
{
$this->api = $api;
}
/**
* @param string $method
* @return string
*/
public function sign(string $method = 'GET')
{
$request = $this->api->getRequest();
ksort($request);
$str = '';
foreach ($request as $key => $value) {
$str .= '&' . $this->charTransfer(urlencode($key)) . '=' . $this->charTransfer(urlencode($value));
}
$str = trim($str, '&');
$str = urlencode($str);
$str = $method . '&%2F&' . $str;
$hash = hash_hmac('sha1', $str, Config::ACCESS_SECRET . '&', true);
$this->sign = base64_encode($hash);
return $this->sign;
}
/**
* @param string $res
* @return string
*/
private function charTransfer(string $res): string
{
// $str = str_replace(['+', '*', '%7E'], ['%20', '%2A', '~'], $str);
$res = preg_replace('/\+/', '%20', $res);
$res = preg_replace('/\*/', '%2A', $res);
$res = preg_replace('/%7E/', '~', $res);
return $res;
}
}
\ No newline at end of file
Lib/custom/MyCustomTransformer.php 0 → 100644
<?php
/**
* Created by PhpStorm.
* User: banice
* Date: 2018/9/20
* Time: 下午3:02
*/
namespace Lib\custom;
use Dingo\Api\Contract\Transformer\Adapter;
use Dingo\Api\Http\Request;
use Dingo\Api\Transformer\Binding;
use Lib\wx\pay\Order;
class MyCustomTransformer implements Adapter
{
private $returnCode = 200;
private $resultCode = 'SUCCESS';
private $errorMessage = '';
private $data = [];
public function __construct(int $returnCode = 200, string $resultCode = 'SUCCESS')
{
$this->returnCode = $returnCode;
$this->resultCode = $resultCode;
}
public function transform($response, $transformer, Binding $binding, Request $request)
{
$data = [];
if ($response instanceof Order) {
$order = $response->getParameters();
$data = [
'appId' => $order['appid'],
'timeStamp' => strval(time()),
'nonceStr' => str_random(32),
'package' => 'prepay_id=' . $order['prepay_id'],
'signType' => config('wx.sign_type'),
];
}
return array_filter([
'return_code' => $this->returnCode,
'result_code' => $this->resultCode,
'data' => $data,
], function ($value) {
return filled($value);
});
}
}
\ No newline at end of file
Lib/wx/Client.php
...@@ -9,7 +9,8 @@ ...@@ -9,7 +9,8 @@
namespace Lib\wx; namespace Lib\wx;
use Lib\wx\pay\Order; use Illuminate\Support\Facades\Log;
use Lib\wx\pay\UnifiedOrder;
use Spatie\ArrayToXml\ArrayToXml; use Spatie\ArrayToXml\ArrayToXml;
class Client class Client
...@@ -24,18 +25,28 @@ class Client ...@@ -24,18 +25,28 @@ class Client
* @throws \Exception * @throws \Exception
* @return bool * @return bool
*/ */
public function request(Order $order, string $url): bool public function request(UnifiedOrder $order, string $url): bool
{ {
$client = new \GuzzleHttp\Client(); $client = new \GuzzleHttp\Client();
$content = $order->getOrderRequest(); $content = $order->getOrderRequest();
$sign = Tool::sign($content);
$content['sign'] = $sign;
$body = []; $body = [];
foreach ($content as $key => $value) { foreach ($content as $key => $value) {
$body[$key] = ['_cdate' => $value]; if ($key != 'total_fee') {
$body[$key] = ['_cdata' => $value];
} else {
$body[$key] = $value;
}
} }
$body = ArrayToXml::convert($body); $body = ArrayToXml::convert($body);
$response = $client->post($url, [ $response = $client->post($url, [
...@@ -46,6 +57,7 @@ class Client ...@@ -46,6 +57,7 @@ class Client
if ($response->getStatusCode() === 200) { if ($response->getStatusCode() === 200) {
$this->response = Tool::xmlToArray($response->getBody()->getContents()); $this->response = Tool::xmlToArray($response->getBody()->getContents());
if ($this->response['return_code'] === 'SUCCESS' && Tool::validateSign($this->response) && $this->response['result_code'] === 'SUCCESS') { if ($this->response['return_code'] === 'SUCCESS' && Tool::validateSign($this->response) && $this->response['result_code'] === 'SUCCESS') {
return true; return true;
} }
......
Lib/wx/pay/Order.php
...@@ -9,10 +9,43 @@ ...@@ -9,10 +9,43 @@
namespace Lib\wx\pay; namespace Lib\wx\pay;
interface Order class Order
{ {
private $parameters = [
'appid' => '',
'mch_id' => '',
'device_info' => '',
'nonce_str' => '',
'sign' => '',
'result_code' => '',
'err_code' => '',
'err_code_des' => '',
'trade_type' => '',
'prepay_id' => '',
'code_url' => ''
];
public function parseResponse(array $response)
{
foreach ($response as $key => $value) {
if (isset($this->parameters[$key])) {
$this->parameters[$key] = $value;
}
}
}
/**
* @return array
*/
public function getParameters(): array
{
return $this->parameters;
}
public function getOrderRequest(): array;
} }
\ No newline at end of file
Lib/wx/pay/UnifiedOrder.php
...@@ -6,18 +6,15 @@ ...@@ -6,18 +6,15 @@
* Time: 下午1:07 * Time: 下午1:07
*/ */
namespace Lib\wx; namespace Lib\wx\pay;
use Lib\wx\pay\Order;
use Mockery\Exception;
/** /**
* 微信支付 * 微信支付
* Class Pay * Class Pay
* @package Lib\wx * @package Lib\wx
*/ */
class UnifiedOrder implements Order class UnifiedOrder
{ {
/** /**
...@@ -66,9 +63,9 @@ class UnifiedOrder implements Order ...@@ -66,9 +63,9 @@ class UnifiedOrder implements Order
*/ */
public function __construct() public function __construct()
{ {
$this->requestParameters['appid'] = env('WX_APP_ID'); $this->requestParameters['appid'] = config('wx.app_id');
$this->requestParameters['mch_id'] = env('WX_MCH_ID'); $this->requestParameters['mch_id'] = config('wx.mch_id');
// $urlGenerator = app('Dingo\Api\Routing\UrlGenerator'); // $urlGenerator = app('Dingo\Api\Routing\UrlGenerator');
// //
...@@ -88,7 +85,7 @@ class UnifiedOrder implements Order ...@@ -88,7 +85,7 @@ class UnifiedOrder implements Order
public function getOrderRequest(): array public function getOrderRequest(): array
{ {
$this->requestParameters = array_filter($this->requestParameters, function ($value, $key) { return $this->requestParameters = array_filter($this->requestParameters, function ($value, $key) {
return filled($value); return filled($value);
......
app/Http/Controllers/v1/TestController.php
...@@ -10,6 +10,9 @@ namespace App\Http\Controllers\v1; ...@@ -10,6 +10,9 @@ namespace App\Http\Controllers\v1;
use App\Http\Controllers\Controller; use App\Http\Controllers\Controller;
use App\model\UserModel;
use Illuminate\Support\Facades\DB;
use Lib\custom\MyCustomTransformer;
class TestController extends Controller class TestController extends Controller
{ {
...@@ -17,6 +20,8 @@ class TestController extends Controller ...@@ -17,6 +20,8 @@ class TestController extends Controller
public function test() public function test()
{ {
return $this->response->collection(UserModel::all(), new MyCustomTransformer());
return '123'; return '123';
......
app/Http/Controllers/v1/replace/ReplaceController.php 0 → 100644
<?php
/**
* Created by PhpStorm.
* User: banice
* Date: 2018/9/17
* Time: 下午8:35
*/
namespace App\Http\Controllers\v1\replace;
use App\Http\Controllers\Controller;
use App\model\BoxModel;
use Illuminate\Http\Request;
class ReplaceController extends Controller
{
public function replace(Request $request)
{
// $validator = Validator::make();
//todo 验证舱门的有效性
//todo 舱门唯一id
$boxId = $request->get('box_id');
//todo 检测是否预约 ,舱门状态
BoxModel::where('id',$boxId)->first(['box_code','battery_code','reserve_status'])->toArray();
//todo 下发打开舱门的命令
}
}
\ No newline at end of file
app/Http/Controllers/v1/wx/auth/CodeController.php
...@@ -75,18 +75,23 @@ class CodeController extends Controller ...@@ -75,18 +75,23 @@ class CodeController extends Controller
abort(500, $request); abort(500, $request);
} }
if ($userModel->where('openid', $openId)->update([ $userModel = UserModel::where('telephone', $purePhoneNumber)->first();
'session_key' => $sessionKey,
'telephone' => $phoneNumber,
'pure_phone' => $purePhoneNumber, if ($userModel !== null) {
'country_code' => $countryCode, $userModel->session_key = $sessionKey;
]) === 0) { $userModel->openid = $openId;
$userModel->save();
} else {
$userModel = new UserModel();
if ($userModel->addWxUser($wxUser) === false) { if ($userModel->addWxUser($wxUser) === false) {
abort(500, 'add new user fail'); abort(500, 'add new user fail');
} }
} }
return $this->response->array([ return $this->response->array([
'return_code' => 200, 'return_code' => 200,
......
app/Http/Controllers/v1/wx/auth/RegisterController.php
...@@ -43,7 +43,7 @@ class RegisterController extends Controller ...@@ -43,7 +43,7 @@ class RegisterController extends Controller
abort(400, $validator->errors()->first()); abort(400, $validator->errors()->first());
} }
$telephone = $request->get('phone'); $telephone = $request->get('telephone');
$code = $request->get('code'); $code = $request->get('code');
$sms->setPhone($telephone); $sms->setPhone($telephone);
...@@ -84,7 +84,7 @@ class RegisterController extends Controller ...@@ -84,7 +84,7 @@ class RegisterController extends Controller
$validator = Validator::make($request->all(), [ $validator = Validator::make($request->all(), [
'phone' => 'required|digits:11|exists:guests,telephone', 'telephone' => 'required|digits:11|exists:guests,telephone',
'code' => 'required|digits:4', 'code' => 'required|digits:4',
]); ]);
...@@ -92,7 +92,7 @@ class RegisterController extends Controller ...@@ -92,7 +92,7 @@ class RegisterController extends Controller
if ($validator->fails() === true) { if ($validator->fails() === true) {
abort(400, $validator->errors()->first()); abort(400, $validator->errors()->first());
} }
$phone = $request->get('phone'); $phone = $request->get('telephone');
$code = $request->get('code'); $code = $request->get('code');
$sms->setPhone($phone); $sms->setPhone($phone);
...@@ -105,6 +105,8 @@ class RegisterController extends Controller ...@@ -105,6 +105,8 @@ class RegisterController extends Controller
$token = Auth::login($userModel); $token = Auth::login($userModel);
Log::debug($token);
return $this->response->array($this->getResponseCode() + ['data' => ['token' => $token]]); return $this->response->array($this->getResponseCode() + ['data' => ['token' => $token]]);
......
app/Http/Controllers/v1/wx/pay/CardController.php
...@@ -11,6 +11,12 @@ namespace App\Http\Controllers\v1\wx\pay; ...@@ -11,6 +11,12 @@ namespace App\Http\Controllers\v1\wx\pay;
use App\Http\Controllers\Controller; use App\Http\Controllers\Controller;
use App\model\PayGroupModel; use App\model\PayGroupModel;
use Illuminate\Http\Request;
use Lib\custom\MyCustomTransformer;
use Lib\wx\Client;
use Lib\wx\pay\Order;
use Lib\wx\pay\UnifiedOrder;
use Validator;
class CardController extends Controller class CardController extends Controller
{ {
...@@ -35,6 +41,60 @@ class CardController extends Controller ...@@ -35,6 +41,60 @@ class CardController extends Controller
'items' => $payGroup 'items' => $payGroup
], ],
]); ]);
}
//购买换电卡
/**
* @param Request $request
* @param UnifiedOrder $unifiedOrder
* @return \Dingo\Api\Http\Response
* @throws \Exception
*/
public function pay(Request $request, UnifiedOrder $unifiedOrder)
{
$validator = Validator::make($request->all(), [
'amount' => 'required',
'day' => 'required',
'card_id' => 'required',
]);
if ($validator->fails() === true) {
abort(400, $validator->errors()->first());
}
//todo 验证金额日期id是否一致
$day = $request->get('day');
$amount = $request->get('amount');
$notifyUrl = '';
$openid = 'own8r5AR8dvJqy8GQM_zNX9weR8Y';
$unifiedOrder->setParameters([
'body' => '购买充电卡',
'out_trade_no' => time() . rand(100000, 999999),
'total_fee' => $amount,
'spbill_create_ip' => $request->getClientIp(),
'notify_url' => $notifyUrl,
'trade_type' => 'JSAPI',
'openid' => $openid,
]);
$client = new Client();
if ($client->request($unifiedOrder, config('wx.unified_order_url') === true)) {
$response = $client->getResponse();
$order = new Order();
$order->parseResponse($response);
return $this->response->item($order, new MyCustomTransformer());
} else {
abort(500, 'request order fail');
}
} }
......
app/Http/Controllers/v1/wx/pay/DepositController.php
...@@ -12,10 +12,13 @@ namespace App\Http\Controllers\v1\wx\pay; ...@@ -12,10 +12,13 @@ namespace App\Http\Controllers\v1\wx\pay;
use App\Http\Controllers\Controller; use App\Http\Controllers\Controller;
use App\model\SystemModel; use App\model\SystemModel;
use Illuminate\Http\Request; use Illuminate\Http\Request;
use Lib\custom\MyCustomTransformer;
use Lib\wx\Client; use Lib\wx\Client;
use Lib\wx\login\Login; use Lib\wx\login\Login;
use Lib\wx\UnifiedOrder; use Lib\wx\pay\Order;
use Lib\wx\pay\UnifiedOrder;
use Validator; use Validator;
use Log;
class DepositController extends Controller class DepositController extends Controller
{ {
...@@ -55,22 +58,23 @@ class DepositController extends Controller ...@@ -55,22 +58,23 @@ class DepositController extends Controller
$validator = Validator::make($request->all(), [ $validator = Validator::make($request->all(), [
'amount' => 'required|int', 'amount' => 'required|int',
'code' => 'required' // 'code' => 'required'
]); ]);
$code = $request->get('code'); // $code = $request->get('code');
//
$login = new Login($code); // $login = new Login($code);
if ($login->request() === true) { // if ($login->request() === true) {
$openid = $login->getOpenId(); // $openid = $login->getOpenId();
//fixme 存储用户的sessionId // //fixme 存储用户的sessionId
} // }
$openid = 'own8r5AR8dvJqy8GQM_zNX9weR8Y';
//todo 验证押金金额 //todo 验证押金金额
$amount = $request->get('amount'); $amount = $request->get('amount');
$amount *= 100; $amount *= 100;
$notifyUrl = ''; $notifyUrl = 'http://';
$unifiedOrder->setParameters([ $unifiedOrder->setParameters([
'body' => '支付押金', 'body' => '支付押金',
...@@ -86,6 +90,15 @@ class DepositController extends Controller ...@@ -86,6 +90,15 @@ class DepositController extends Controller
if ($client->request($unifiedOrder, config('wx.unified_order_url')) === true) { if ($client->request($unifiedOrder, config('wx.unified_order_url')) === true) {
$response = $client->getResponse();
$order = new Order();
$order->parseResponse($response);
return $this->response->item($order, new MyCustomTransformer());
} else {
dd('error');
} }
......
app/Http/Controllers/v1/wx/pay/TopUpController.php
...@@ -11,11 +11,23 @@ namespace App\Http\Controllers\v1\wx\pay; ...@@ -11,11 +11,23 @@ namespace App\Http\Controllers\v1\wx\pay;
use App\Http\Controllers\Controller; use App\Http\Controllers\Controller;
use App\model\PayGroupModel; use App\model\PayGroupModel;
use Carbon\Carbon; use Illuminate\Http\Request;
use Lib\custom\MyCustomTransformer;
use Lib\wx\Client;
use Lib\wx\pay\Order;
use Lib\wx\pay\UnifiedOrder;
use Validator;
/**
* 充值
* Class TopUpController
* @package App\Http\Controllers\v1\wx\pay
*/
class TopUpController extends Controller class TopUpController extends Controller
{ {
public function get() public function get()
{ {
$date = date('Y-m-d H:i:s'); $date = date('Y-m-d H:i:s');
...@@ -39,4 +51,80 @@ class TopUpController extends Controller ...@@ -39,4 +51,80 @@ class TopUpController extends Controller
]); ]);
} }
}
\ No newline at end of file /**
* 余额充值
* @param Request $request
* @param UnifiedOrder $unifiedOrder
* @return \Dingo\Api\Http\Response
* @throws \Exception
*/
public function pay(Request $request, UnifiedOrder $unifiedOrder)
{
$validator = Validator::make($request->all(), [
'amount' => 'required',
'code' => 'required'
]);
if ($validator->fails() === true) {
abort(400, $validator->errors()->first());
}
//todo code 获取openid和更新session id 验证金额
$amount = $request->get('amount');
$openid = 'own8r5AR8dvJqy8GQM_zNX9weR8Y';
$notifyUrl = '';
$unifiedOrder->setParameters([
'body' => '余额充值',
'out_trade_no' => time() . rand(100000, 999999),
'total_fee' => $amount,
'spbill_create_ip' => $request->getClientIp(),
'notify_url' => $notifyUrl,
'trade_type' => 'JSAPI',
'openid' => $openid,
]);
$client = new Client();
if ($client->request($unifiedOrder, config('wx.unified_order_url') === true)) {
$response = $client->getResponse();
$order = new Order();
$order->parseResponse($response);
return $this->response->item($order, new MyCustomTransformer());
} else {
abort(500, 'request order fail');
}
}
}
app/model/BoxModel.php 0 → 100644
<?php
/**
* Created by PhpStorm.
* User: banice
* Date: 2018/9/17
* Time: 下午8:40
*/
namespace App\model;
use Illuminate\Database\Eloquent\Model;
class BoxModel extends Model
{
protected $table = 'box_rooms';
}
\ No newline at end of file
bootstrap/app.php
...@@ -24,11 +24,16 @@ $app = new Laravel\Lumen\Application( ...@@ -24,11 +24,16 @@ $app = new Laravel\Lumen\Application(
); );
$app->configure('logging');
$app->configure('auth'); $app->configure('auth');
$app->configure('logging');
$app->configure('dysms'); $app->configure('dysms');
$app->configure('wx');
$app->configure('mqtt');
$app->configure('redis_key');
$app->withFacades(); $app->withFacades();
...@@ -87,6 +92,7 @@ $app->routeMiddleware([ ...@@ -87,6 +92,7 @@ $app->routeMiddleware([
// 'auth' => App\Http\Middleware\Authenticate::class, // 'auth' => App\Http\Middleware\Authenticate::class,
// ]); // ]);
/* /*
|-------------------------------------------------------------------------- |--------------------------------------------------------------------------
| Register Service Providers | Register Service Providers
...@@ -123,11 +129,17 @@ $app['Dingo\Api\Auth\Auth']->extend('oauth', function ($app) { ...@@ -123,11 +129,17 @@ $app['Dingo\Api\Auth\Auth']->extend('oauth', function ($app) {
return new Dingo\Api\Auth\Provider\JWT($app['Tymon\JWTAuth\JWTAuth']); return new Dingo\Api\Auth\Provider\JWT($app['Tymon\JWTAuth\JWTAuth']);
}); });
app('Dingo\Api\Transformer\Factory')->setAdapter(function ($app) { //app('Dingo\Api\Transformer\Factory')->setAdapter(function ($app) {
//
//
// return new Dingo\Api\Transformer\Adapter\Fractal(new League\Fractal\Manager, 'include', ',');
//
//});
app('Dingo\Api\Transformer\Factory')->setAdapter(function ($app) {
return new \Lib\custom\MyCustomTransformer();
return new Dingo\Api\Transformer\Adapter\Fractal(new League\Fractal\Manager, 'include', ','); return new Dingo\Api\Transformer\Adapter\Fractal(new League\Fractal\Manager, 'include', ',');
}); });
$app['Dingo\Api\Exception\Handler']->setErrorFormat([ $app['Dingo\Api\Exception\Handler']->setErrorFormat([
......
composer.json
{ {
"name": "laravel/lumen", "name": "laravel/lumen",
"description": "The Laravel Lumen Framework.", "description": "The Laravel Lumen Framework.",
"keywords": ["framework", "laravel", "lumen"], "keywords": [
"license": "MIT", "framework",
"type": "project", "laravel",
"require": { "lumen"
"php": ">=5.6.4", ],
"laravel/lumen-framework": "5.5.*", "license": "MIT",
"vlucas/phpdotenv": "~2.2", "type": "project",
"dingo/api": "2.0.0-alpha1", "require": {
"tymon/jwt-auth": "^1.0@dev", "php": ">=5.6.4",
"guzzlehttp/guzzle": "~6.0", "laravel/lumen-framework": "5.5.*",
"flc/dysms": "^1.0", "vlucas/phpdotenv": "~2.2",
"spatie/array-to-xml": "^2.7", "dingo/api": "2.0.0-alpha1",
"overtrue/laravel-lang": "^3.0" "tymon/jwt-auth": "^1.0@dev",
}, "guzzlehttp/guzzle": "~6.0",
"require-dev": { "flc/dysms": "^1.0",
"fzaninotto/faker": "~1.4", "spatie/array-to-xml": "^2.7",
"phpunit/phpunit": "~6.0", "overtrue/laravel-lang": "^3.0"
"mockery/mockery": "~0.9" },
}, "require-dev": {
"autoload": { "fzaninotto/faker": "~1.4",
"psr-4": { "phpunit/phpunit": "~6.0",
"App\\": "app/", "mockery/mockery": "~0.9"
"Lib\\": "Lib/" },
} "autoload": {
}, "psr-4": {
"autoload-dev": { "App\\": "app/",
"classmap": [ "Lib\\": "Lib/",
"tests/", "Src\\": "src/"
"database/" }
] },
}, "autoload-dev": {
"scripts": { "classmap": [
"post-root-package-install": [ "tests/",
"php -r \"copy('.env.example', '.env');\"" "database/"
] ]
}, },
"minimum-stability": "dev", "scripts": {
"prefer-stable": true, "post-root-package-install": [
"optimize-autoloader": true "php -r \"copy('.env.example', '.env');\""
]
},
"minimum-stability": "dev",
"prefer-stable": true,
"optimize-autoloader": true
} }
config/database.php
...@@ -47,66 +47,50 @@ return [ ...@@ -47,66 +47,50 @@ return [
'connections' => [ 'connections' => [
'testing' => [ 'testing' => [
'driver' => 'sqlite', 'driver' => 'sqlite',
'database' => ':memory:', 'database' => ':memory:',
], ],
'sqlite' => [ 'sqlite' => [
'driver' => 'sqlite', 'driver' => 'sqlite',
'database' => env('DB_DATABASE', base_path('database/database.sqlite')), 'database' => env('DB_DATABASE', base_path('database/database.sqlite')),
'prefix' => env('DB_PREFIX', ''), 'prefix' => env('DB_PREFIX', ''),
], ],
'mysql' => [ 'mysql' => [
'driver' => 'mysql', 'driver' => 'mysql',
'host' => env('DB_HOST', 'localhost'), 'host' => env('DB_HOST', 'localhost'),
'port' => env('DB_PORT', 3306), 'port' => env('DB_PORT', 3306),
'database' => env('DB_DATABASE', 'forge'), 'database' => env('DB_DATABASE', 'forge'),
'username' => env('DB_USERNAME', 'forge'), 'username' => env('DB_USERNAME', 'forge'),
'password' => env('DB_PASSWORD', ''), 'password' => env('DB_PASSWORD', ''),
'charset' => env('DB_CHARSET', 'utf8mb4'), 'charset' => env('DB_CHARSET', 'utf8mb4'),
'collation' => env('DB_COLLATION', 'utf8mb4_unicode_ci'),
'prefix' => env('DB_PREFIX', ''),
'timezone' => env('DB_TIMEZONE', '+08:00'),
'strict' => env('DB_STRICT_MODE', false),
],
'old_cdz' => [
'driver' => 'mysql',
'host' => env('PRE_DB_HOST'),
'port' => env('PRE_DB_PORT', 3306),
'database' => env('PRE_DB_DATABASE'),
'username' => env('PRE_DB_USERNAME'),
'password' => env('PRE_DB_PASSWORD'),
'charset' => env('DB_CHARSET', 'utf8mb4'),
'collation' => env('DB_COLLATION', 'utf8mb4_unicode_ci'), 'collation' => env('DB_COLLATION', 'utf8mb4_unicode_ci'),
'prefix' => env('DB_PREFIX', ''), 'prefix' => env('DB_PREFIX', ''),
'timezone' => env('DB_TIMEZONE', '+08:00'), 'timezone' => env('DB_TIMEZONE', '+08:00'),
'strict' => env('DB_STRICT_MODE', false), 'strict' => env('DB_STRICT_MODE', false),
], ],
'pgsql' => [ 'pgsql' => [
'driver' => 'pgsql', 'driver' => 'pgsql',
'host' => env('DB_HOST', 'localhost'), 'host' => env('DB_HOST', 'localhost'),
'port' => env('DB_PORT', 5432), 'port' => env('DB_PORT', 5432),
'database' => env('DB_DATABASE', 'forge'), 'database' => env('DB_DATABASE', 'forge'),
'username' => env('DB_USERNAME', 'forge'), 'username' => env('DB_USERNAME', 'forge'),
'password' => env('DB_PASSWORD', ''), 'password' => env('DB_PASSWORD', ''),
'charset' => env('DB_CHARSET', 'utf8'), 'charset' => env('DB_CHARSET', 'utf8'),
'prefix' => env('DB_PREFIX', ''), 'prefix' => env('DB_PREFIX', ''),
'schema' => env('DB_SCHEMA', 'public'), 'schema' => env('DB_SCHEMA', 'public'),
], ],
'sqlsrv' => [ 'sqlsrv' => [
'driver' => 'sqlsrv', 'driver' => 'sqlsrv',
'host' => env('DB_HOST', 'localhost'), 'host' => env('DB_HOST', 'localhost'),
'database' => env('DB_DATABASE', 'forge'), 'database' => env('DB_DATABASE', 'forge'),
'username' => env('DB_USERNAME', 'forge'), 'username' => env('DB_USERNAME', 'forge'),
'password' => env('DB_PASSWORD', ''), 'password' => env('DB_PASSWORD', ''),
'charset' => env('DB_CHARSET', 'utf8'), 'charset' => env('DB_CHARSET', 'utf8'),
'prefix' => env('DB_PREFIX', ''), 'prefix' => env('DB_PREFIX', ''),
], ],
], ],
...@@ -140,8 +124,8 @@ return [ ...@@ -140,8 +124,8 @@ return [
'cluster' => env('REDIS_CLUSTER', false), 'cluster' => env('REDIS_CLUSTER', false),
'default' => [ 'default' => [
'host' => env('REDIS_HOST', '127.0.0.1'), 'host' => env('REDIS_HOST', '127.0.0.1'),
'port' => env('REDIS_PORT', 6379), 'port' => env('REDIS_PORT', 6379),
'database' => env('REDIS_DATABASE', 4), 'database' => env('REDIS_DATABASE', 4),
'password' => env('REDIS_PASSWORD', null), 'password' => env('REDIS_PASSWORD', null),
], ],
......
config/mqtt.php 0 → 100644
<?php
/**
* Created by PhpStorm.
* User: banice
* Date: 2018/9/27
* Time: 下午5:19
*/
return [
'hdg' => [
'product_key' => env('MQTT_PRODUCT_KEY'),
'format' => 'json',
'version' => '2018-01-20',
'access_key_id' => env('MQTT_ACCESS_KEY_ID', 'LTAItZVbkVaVXifu'),
'sign_method' => 'HMAC-SHA1',
'sign_version' => '1.0',
'region_id' => 'cn-shanghai',
'access_secret' => env('MQTT_ACCESS_SECRET', 'Irko4313cUEbb1RYXGWEz6s6VgNETG'),
'access_key' => env('MQTT_ACCESS_KEY', 'LTAItZVbkVaVXifu'),
]
];
config/redis_key.php 0 → 100644
<?php
/**
* Created by PhpStorm.
* User: banice
* Date: 2018/9/27
* Time: 上午11:23
*/
return [
'AC_ALARM' => 'hdg:ac:alarm:hash'
];
config/wx.php
...@@ -26,5 +26,6 @@ return [ ...@@ -26,5 +26,6 @@ return [
'lang' => env('WX_LANG'), 'lang' => env('WX_LANG'),
'app_key' => env('WX_APP_KEY'), 'app_key' => env('WX_APP_KEY'),
'unified_order_url' => 'https://api.mch.weixin.qq.com/pay/unifiedorder', 'unified_order_url' => 'https://api.mch.weixin.qq.com/pay/unifiedorder',
'sign_type' => 'MD5',
]; ];
\ No newline at end of file
doc/test.php 0 → 100644
<?php
$data = [
'err_alarm_type' => [0, 0, 0, 0, 0, 0],
'sensor_bean_count' => 3,
'sensor_bean' => [
[
'humidity' => 1,
'temperature' => 1,
'sensor_state' => 1,
'retain' => 0,
],
[
'humidity' => 1,
'temperature' => 1,
'sensor_state' => 1,
'retain' => 0,
],
[
'humidity' => 1,
'temperature' => 1,
'sensor_state' => 1,
'retain' => 0,
]
],
'sensor_smoke_count' => 1,
'sensor_smoke' => [
[
'white_smoke' => 1,
'black_smoke' => 1,
'device_state' => 1,
'retain' => 0,
]
]
];
$data = [
'ntc_count' => 3,
'ntc' => [
40, 50, 60
],
'humidity_count' => 3,
'humidity' => [2, 3, 4],
'while_smoke' => 0,
'black_smoke' => 0,
];
$data = [
'box_id' => 1,
'site' => '利尔达',
'user' => 'admin',
'password' => 'admin',
];
$data = [
'hardware_version' => '1.0',
'software_version' => '1.0',
'reserve' => ''
];
$data = [
'door_count' => 10,
'door' => [
'box_num' => 1,
'battery_num' => '2312313',
'err_lock' => 0,
'err_lock_bat' => 0,
'lock_state' => 1,
'battery_state' => 1,
'door_num' => 1
]
];
echo json_encode($data);
?>
\ No newline at end of file
routes/web.php
...@@ -12,6 +12,7 @@ ...@@ -12,6 +12,7 @@
*/ */
$router->get('/', function () use ($router) { $router->get('/', function () use ($router) {
return $router->app->version(); return $router->app->version();
}); });
...@@ -22,11 +23,7 @@ $api = app('Dingo\Api\Routing\Router'); ...@@ -22,11 +23,7 @@ $api = app('Dingo\Api\Routing\Router');
$api->version('v1', ['namespace' => 'App\Http\Controllers\v1', 'prefix' => 'api/wx', 'middleware' => ['addResultCode']], function ($api) { $api->version('v1', ['namespace' => 'App\Http\Controllers\v1', 'prefix' => 'api/wx', 'middleware' => ['addResultCode']], function ($api) {
$api->post('test', function () { $api->get('test', 'TestController@test');
dd(1);
});
$api->get('code', 'wx\auth\CodeController@login'); $api->get('code', 'wx\auth\CodeController@login');
...@@ -42,10 +39,16 @@ $api->version('v1', ['namespace' => 'App\Http\Controllers\v1', 'prefix' => 'api/ ...@@ -42,10 +39,16 @@ $api->version('v1', ['namespace' => 'App\Http\Controllers\v1', 'prefix' => 'api/
$api->get('card/items', 'wx\pay\CardController@get'); $api->get('card/items', 'wx\pay\CardController@get');
//
$api->get('deposit/order', 'wx\pay\DepositController@pay');
$api->group(['prefix' => '', 'middleware' => 'auth:api'], function ($api) { $api->group(['prefix' => '', 'middleware' => 'auth:api'], function ($api) {
$api->get('tickets', 'wx\pay\ActivityController@getTicket'); $api->get('tickets', 'wx\pay\ActivityController@getTicket');
//
}); });
}); });
......
src/box/Box.php 0 → 100644
<?php
/**
* Created by PhpStorm.
* User: banice
* Date: 2018/9/26
* Time: 下午2:03
*/
namespace src\box;
use App\Http\model\DoorModel;
use src\box\door\Door;
class Box
{
use SearchModel;
private $id = 0;
private $code = '';
private $type = 1;
public function __construct(int $id = 0)
{
$this->id = $id;
}
/**
* @return int
*/
public function getId(): int
{
return $this->id;
}
/**
* @param int $id
*/
public function setId(int $id): void
{
$this->id = $id;
}
/**
* @return string
*/
public function getCode(): string
{
return $this->code;
}
/**
* @param string $code
*/
public function setCode(string $code): void
{
$this->code = $code;
}
/**
* @param int $doorCount
*/
public function initDoor(int $doorCount = 16): void
{
$i = 1;
while ($doorCount--) {
$door = new Door();
$door->setName($i++);
$door->setBoxId($this->id);
$door->setBoxType($this->type);
$doorModel = new DoorModel();
$doorModel->add($door);
unset($door);
unset($doorModel);
}
}
}
\ No newline at end of file
src/box/SearchModel.php 0 → 100644
<?php
/**
* Created by PhpStorm.
* User: banice
* Date: 2018/9/26
* Time: 下午2:06
*/
namespace src\box;
use App\Http\model\BoxModel;
trait SearchModel
{
/**
* @var BoxModel
*/
protected $boxModel;
/**
* @param string $code
* @param array $parameters
* @return bool
*/
public function searchByCode(string $code, array $parameters = []): bool
{
$this->boxModel = BoxModel::where([['code', $code], ['box_type', 0]])->first($parameters);
return $this->boxModel === null ? false : true;
}
/**
* @param string $code
* @param int $num
* @param array $parameters
* @return bool
*/
public function searchByCodeNum(string $code, int $num, array $parameters = []): bool
{
$this->boxModel = BoxModel::where([['code', $code], ['box_type', $num]])->first($parameters);
return $this->boxModel === null ? false : true;
}
/**
* @return BoxModel
*/
public function getBoxModel(): BoxModel
{
return $this->boxModel;
}
/**
* @param BoxModel $boxModel
*/
public function setBoxModel(BoxModel $boxModel): void
{
$this->boxModel = $boxModel;
}
/**
* @param string $parameter
* @return mixed
*/
public function getValue(string $parameter)
{
return $this->boxModel->$parameter;
}
}
\ No newline at end of file
src/box/ac/Alarm.php 0 → 100644
<?php
/**
* Created by PhpStorm.
* User: banice
* Date: 2018/9/27
* Time: 上午10:52
*/
namespace src\box\ac;
use Illuminate\Support\Facades\Redis;
class Alarm
{
private $boxId;
/**
* @var array 湿度
*/
private $humidity = [];
/**
* @var array 温度
*/
private $temperature = [];
private $sensorState = [];
/**
* @var array 保留
*/
private $retain = [];
/**
* @var int 白烟
*/
private $whiteSmoke = 0;
/**
* @var int 黑烟
*/
private $blackSmoke = 0;
/**
* @var int 设备状态
*/
private $deviceState = 0;
/**
* @var int 预留
*/
private $acRetain = 0;
/**
* 更新所有报警数据至redis
*/
public function updateAllToRedis()
{
$redis = app('Redis');
$update = [];
$i = 1;
foreach ([
'humidity' => $this->humidity,
'temperature' => $this->temperature,
'sensor_state' => $this->sensorState,
'retain' => $this->retain,
] as $key => $items) {
$i = 1;
foreach ($items as $item) {
$update[$key . '_' . $i++] = $item;
}
}
$update['white_smoke'] = $this->whiteSmoke;
$update['black_smoke'] = $this->blackSmoke;
$update['device_state'] = $this->deviceState;
$update['retain'] = $this->acRetain;
if ($redis instanceof \Redis) {
$redis->hMset(config('redis_key.AC_ALARM') . ':' . $this->boxId, $update);
}
}
/**
* @return array
*/
public function getHumidity(): array
{
return $this->humidity;
}
/**
* @param array $humidity
*/
public function setHumidity(array $humidity): void
{
$this->humidity = $humidity;
}
/**
* @return array
*/
public function getTemperature(): array
{
return $this->temperature;
}
/**
* @param array $temperature
*/
public function setTemperature(array $temperature): void
{
$this->temperature = $temperature;
}
/**
* @return array
*/
public function getSensorState(): array
{
return $this->sensorState;
}
/**
* @param array $sensorState
*/
public function setSensorState(array $sensorState): void
{
$this->sensorState = $sensorState;
}
/**
* @return array
*/
public function getRetain(): array
{
return $this->retain;
}
/**
* @param array $retain
*/
public function setRetain(array $retain): void
{
$this->retain = $retain;
}
/**
* @return int
*/
public function getWhiteSmoke(): int
{
return $this->whiteSmoke;
}
/**
* @param int $whiteSmoke
*/
public function setWhiteSmoke(int $whiteSmoke): void
{
$this->whiteSmoke = $whiteSmoke;
}
/**
* @return int
*/
public function getBlackSmoke(): int
{
return $this->blackSmoke;
}
/**
* @param int $blackSmoke
*/
public function setBlackSmoke(int $blackSmoke): void
{
$this->blackSmoke = $blackSmoke;
}
/**
* @return int
*/
public function getDeviceState(): int
{
return $this->deviceState;
}
/**
* @param int $deviceState
*/
public function setDeviceState(int $deviceState): void
{
$this->deviceState = $deviceState;
}
/**
* @return mixed
*/
public function getBoxId()
{
return $this->boxId;
}
/**
* @param mixed $boxId
*/
public function setBoxId($boxId): void
{
$this->boxId = $boxId;
}
/**
* @return int
*/
public function getAcRetain(): int
{
return $this->acRetain;
}
/**
* @param int $acRetain
*/
public function setAcRetain(int $acRetain): void
{
$this->acRetain = $acRetain;
}
}
\ No newline at end of file
src/box/door/Door.php 0 → 100644
<?php
/**
* Created by PhpStorm.
* User: banice
* Date: 2018/9/26
* Time: 下午3:20
*/
namespace src\box\door;
class Door
{
/**
* @var int
*/
private $id = 0;
/**
* @var int
*/
private $name = 1;
/**
* @var int
*/
private $boxId = 0;
/**
* @var int
*/
private $boxType = 1;
/**
* @return int
*/
public function getId(): int
{
return $this->id;
}
/**
* @param int $id
*/
public function setId(int $id): void
{
$this->id = $id;
}
/**
* @return int
*/
public function getName(): int
{
return $this->name;
}
/**
* @param int $name
*/
public function setName(int $name): void
{
$this->name = $name;
}
/**
* @return int
*/
public function getBoxId(): int
{
return $this->boxId;
}
/**
* @param int $boxId
*/
public function setBoxId(int $boxId): void
{
$this->boxId = $boxId;
}
/**
* @return int
*/
public function getBoxType(): int
{
return $this->boxType;
}
/**
* @param int $boxType
*/
public function setBoxType(int $boxType): void
{
$this->boxType = $boxType;
}
}
\ No newline at end of file
src/box/door/Open.php 0 → 100644
<?php
/**
* Created by PhpStorm.
* User: banice
* Date: 2018/9/27
* Time: 下午5:13
*/
namespace src\box\door;
use Illuminate\Support\Facades\Log;
use Lib\aliyun\api\PublishToTopic;
use Lib\aliyun\Client;
trait Open
{
public function controlDoor(int $boxNum, int $doorNum, string $orderId, string $deviceName, string $topic = 'get', int $operation = 1)
{
$publishToTopic = new PublishToTopic();
$publishToTopic->setMessageContent(json_encode([
'command' => config('command.open_door'),
'doors' => [
'box_num' => $boxNum,
'door_num' => $doorNum,
'order_id' => $orderId,
'operation' => $operation
]
]));
$publishToTopic->setProductKey('a1pZNA3yDdm');
$topicFullName = '/' . env('MQTT_PRODUCT_KEY') . '/' . $deviceName . '/' . $topic;
$publishToTopic->setTopicFullName($topicFullName);
$client = new Client();
$client->setApi($publishToTopic);
if ($client->request() === true) {
Log::debug('success');
}
}
}
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment