food_server/FlyCube/MpApi/Controller/PublicController.class.php

<?php

namespace MpApi\Controller;

use Think\Controller;

use Firebase\JWT\JWT;
use Firebase\JWT\Key;

use PhpMqtt\Client\MqttClient;
use PhpMqtt\Client\Exceptions\MqttClientException;
use PhpMqtt\Client\ConnectionSettings;

class PublicController extends Controller
{
	protected $tokenShop_id;
	//****************
	//构造函数
	//****************
	public function _initialize()
	{
		header("Access-Control-Allow-Origin: *"); // 允许所有来源
		header("Access-Control-Allow-Methods: GET, POST, OPTIONS"); // 允许的请求方法
		header("Access-Control-Allow-Headers: Content-Type, Authorization,Token"); // 允许的请求头
		// 获取请求头中的 Token
		$token = isset($_SERVER['HTTP_TOKEN']) ? $_SERVER['HTTP_TOKEN'] : null;
		// 获取 jwt 密钥
		$jwtKey = C('jwtKey');
		try {
			// 解码 JWT Token
			$decoded = JWT::decode($token, new Key($jwtKey, 'HS256'));
			// Token 没有过期，继续处理 token验证通过 获取shop_id
			$this->tokenShop_id = $decoded->shop_id;
		} catch (\Firebase\JWT\ExpiredException $e) {
			// Token 过期
			echo json_encode(array('status' => 'noPermission', 'msg' => 'Token 已过期'));
			exit();
		} catch (\Exception $e) {
			// 其他 JWT 解码错误
			echo json_encode(array('status' => 'noPermission', 'msg' => 'Token 解码失败'));
			exit();
		} catch (\TypeError $e) {
			// 处理 Token 为 null 或者不是字符串的情况
			echo json_encode(array('status' => 'noPermission', 'msg' => 'Token 无效'));
			exit();
		}
	}

	/**
	 * @description: 总管理员 可接收任何shop_id 非总管理员 只可以调用自身shop_id 否则会中断
	 */
	protected function isPower()
	{
		if ($this->tokenShop_id != C('powerId')) { //非总管理员
			if ($this->tokenShop_id != $_REQUEST['shop_id']) { // 提交的不是自己shopid退出
				echo json_encode(array('status' => 0, 'msg' => '没有权限'));
				exit;
			}
		}
	}
	/**
	 * @description: 远程调取页面 求情API
	 */
	protected function apiUrl($url, $data = null)
	{
		$ch = curl_init();
		$header = array("Accept-Charset: utf-8"); // 将字符串改为数组
		curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
		curl_setopt($ch, CURLOPT_URL, $url);
		curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE);
		curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, FALSE);
		curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
		curl_setopt($ch, CURLOPT_USERAGENT, 'Mozilla/5.0 (compatible; MSIE 5.01; Windows NT 5.0)');
		curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 1);
		curl_setopt($ch, CURLOPT_AUTOREFERER, 1);

		curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "POST");
		curl_setopt($ch, CURLOPT_POSTFIELDS, $data);

		$output = curl_exec($ch);
		curl_close($ch);
		if ($output) {
			return $output;
		} else {
			return false;
		}
	}
	/**
	 * @Description: 获取token
	 * @Return: token
	 */
	protected function getAccessToken()
	{
		$appId = C("weixin")['appid'];
		$secret = C("weixin")['secret'];
		//创建请求数据
		$url_token = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid={$appId}&secret={$secret}";
		$data_result = $this->apiUrl($url_token);
		$jsoninfo = json_decode($data_result, true);
		return $jsoninfo["access_token"];
	}
	/**
	 * @description: 中文字符串截取
	 * @param {*} $title 要截取的文本
	 * @param {*} $title 截取长度
	 * @return {*} 截取完成后的文本
	 */
	protected function str_substr($title, $length)
	{
		$encoding = 'utf-8';
		if (mb_strlen($title, $encoding) > $length) {
			$title = mb_substr($title, 0, $length, $encoding) . '...';
		}
		return $title;
	}
	/**
	 * @description: 文件上传公共方法
	 * @param {file} $file 表单文件
	 * @param {array} $exts 类型限制 ps: array('png', 'jpg', 'jpeg', 'gif')
	 * @param {file} $path 上传保存的路径
	 * @return {*} 上传信息
	 */
	protected function upload_images($file, $exts, $path)
	{
		$upload = new \Think\Upload(); // 实例化上传类
		$upload->maxSize   =  2097152; // 设置附件上传大小2M
		$upload->exts      =  $exts; // 设置附件上传类型
		$upload->rootPath  =  './Data/UploadFiles/'; // 设置附件上传根目录
		$upload->savePath  =  ''; // 设置附件上传（子）目录
		$upload->saveName = time() . mt_rand(100000, 999999); //文件名称创建时间戳+随机数
		$upload->autoSub  = true; //自动使用子目录保存上传文件 默认为true
		$upload->subName  = $path; //子目录创建方式，采用数组或者字符串方式定义
		// 上传文件 
		$info = $upload->uploadOne($file);
		if (!$info) { // 上传错误提示错误信息
			return $upload->getError();
		} else { // 上传成功 获取上传文件信息
			return $info;
		}
	}
	/**
	 * @description: element 图片上传控件 接收
	 */
	public function upImgFile()
	{
		if ($this->tokenShop_id) {
			$upfile = $this->upload_images($_FILES["file"], array('png', 'jpg', 'jpeg', 'gif', 'svg'), 'temp');
			if (is_array($upfile)) {
				echo json_encode(array('status' => 1, 'msg' => '上传成功', 'data' => $upfile['savename']));
			} else {
				echo json_encode(array('status' => 0, 'msg' => $upfile));
			}
		} else {
			echo json_encode(array('status' => 0, 'msg' => '登录异常'));
		}
	}
	/**
	 * @description: 连接mqtt服务器 并向指定主题发布信息
	 * @param string $topic mqtt主题
	 * @param string $msg 要发布的主题
	 */
	protected function publish($topic, $msg)
	{
		$server   = C('mqtt')['server'];         // MQTT 代理地址
		$port     = C('mqtt')['port'];                    // MQTT 代理端口
		$clientId = C('mqtt')['client_id'];        // 客户端 ID
		$username = C('mqtt')['username'];                 // 用户名（如果需要）
		$password = C('mqtt')['password'];                // 密码（如果需要）

		try {
			// 创建连接设置对象
			$settings = (new ConnectionSettings)->setUsername($username)->setPassword($password);
			// 实例化 MQTT 客户端
			$mqtt = new MqttClient($server, $port, $clientId);
			// 连接到 MQTT 代理
			$mqtt->connect($settings);
			// 检查是否连接成功
			if ($mqtt->isConnected()) {
				// 发布消息到指定的主题 ps:主题  信息  qos
				$mqtt->publish($topic, $msg, 0);
				// 断开连接
				$mqtt->disconnect();
			} else {
				echo "连接失败";
			}
		} catch (MqttClientException $e) { //连接失败
			echo "Could not connect to MQTT broker: " . $e->getMessage();
		}
	}
	/**
	 * @abstract 写入日志
	 */
	public function addLog()
	{
		if ($this->tokenShop_id) {
			$data['shop_id'] = $this->tokenShop_id;
			$data['log'] = $_REQUEST['log'];
			$data['time'] = time();
			if (D('log')->add($data)) {
				echo json_encode(array('status' => 1, 'msg' => '添加成功'));
			} else {
				echo json_encode(array('status' => 0, 'msg' => '添加失败'));
			}
		} else {
			echo json_encode(array('status' => 0, 'msg' => '登录异常'));
		}
	}
}