Food/food_server
3
0
Fork 0
Code Issues 10 Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'master' of http://111.229.174.37:3000/Food/food_server

Browse Source
This commit is contained in:
szdot 2024-06-05 19:59:56 +08:00
commit ac0b5fbd94
1 changed files with 38 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
FlyCube/Api/Controller/PayController.class.php
View File

@ -3,6 +3,10 @@
namespace Api\Controller;
use Yansongda\Pay\Pay;
use PhpMqtt\Client\MqttClient;
use PhpMqtt\Client\Exceptions\MqttClientException;
use PhpMqtt\Client\ConnectionSettings;
use PhpMqtt\Client\Message;
class PayController extends PublicController
{
@ -58,7 +62,7 @@ class PayController extends PublicController
//设置获取签名的订单参数
$orderParameter = [
'out_trade_no' => $order['order_sn'],
'description' => $order['shop_id'],
'description' => $order['shop_id'], //商品名称
'amount' => [
'total' => $order['total_price'] * 100, //单位:分
'currency' => 'CNY',
@ -78,14 +82,42 @@ class PayController extends PublicController
public function notifyCallback()
{
$pay = Pay::wechat($this->config);
$server = 'www.szdot.top'; // MQTT 代理地址
$port = 1883; // MQTT 代理端口
$clientId = 'php-mqtt-client'; // 客户端 ID
$username = 'admin'; // 用户名（如果需要）
$password = '123456'; // 密码（如果需要）
try {
$data = $pay->callback(); // 是的，验签就这么简单！
} catch (\Exception $e) {
// $e->getMessage();
// 创建连接设置对象
$settings = (new ConnectionSettings)->setUsername($username)->setPassword($password);
// 实例化 MQTT 客户端
$mqtt = new MqttClient($server, $port, $clientId);
// 连接到 MQTT 代理
$mqtt->connect($settings);
// 检查是否连接成功
if ($mqtt->isConnected()) {
echo "连接成功";
// 发布消息到指定的主题 ps:主题 信息 qos
$mqtt->publish('demo', 'Hello MQTT', 0);
// 断开连接
$mqtt->disconnect();
echo "断开连接";
} else {
echo "连接失败";
}
} catch (MqttClientException $e) { //连接失败
echo "Could not connect to MQTT broker: " . $e->getMessage();
}
// $pay = Pay::wechat($this->config);
// try {
// $data = $pay->callback(); // 是的，验签就这么简单！
// } catch (\Exception $e) {
// // $e->getMessage();
// }
// return $pay->success();
return $pay->success();
}
}