private $host;

private $port;

private $authorization_file = './authorization.txt';//通信鉴权密钥存储路径

private $authorization;

private $robot_master = [//机器人主人 后面的程序 你可以自由判断是否必须主人才可操作 自行发挥

'sundreamer',

];

private $events = [//开发了新功能，就需要在对应的事件下面加入进去例如【'music' => 1】指的是点歌插件=>开启(1 开启 0 关闭)

'EventLogin' => [//新的账号登录成功/下线时

],

'EventGroupMsg'=> [//群消息事件（收到群消息时，运行这里）

'music' => 1,

'douyin' =>1,

'replay_video'=>1

],

'EventFriendMsg'=> [//私聊消息事件（收到私聊消息时，运行这里）

'music' => 1,

'douyin' =>1,

'replay_text'=>1,

'replay_img'=>1,

'replay_video'=>1,

'replay_file_msg'=>1,

'replay_emjoy_msg'=>1,

'replay_link_msg'=>1,

'replay_music_msg'=>1,

],

'EventReceivedTransfer'=> [//收到转账事件（收到好友转账时，运行这里）

],

'EventScanCashMoney'=> [//面对面收款（二维码收款时，运行这里）

],

'EventFriendVerify'=> [//好友请求事件（插件3.0版本及以上）

],

'EventContactsChange'=> [//朋友变动事件（插件4.0版本及以上，当前为测试版，还未启用，留以备用）

],

'EventGroupMemberAdd'=> [//群成员增加事件（新人进群）

],

'EventGroupMemberDecrease'=> [//群成员减少事件（群成员退出）

],

'EventSysMsg'=> [//系统消息事件

],

];

/**

public static function init($host = '127.0.0.1', $port = 8090)

{

return new static($host, $port);

}

/**

public function __construct($host = '127.0.0.1', $port = 8090)

{

$this->host = $host;

$this->port = $port;

if(!is_file($this->authorization_file))

$this->setAuthorization();

$this->authorization = $this->getAuthorization();

}

/**

public function index(){

header("Content-type: text/html; charset=utf-8");

date_default_timezone_set("PRC");//设置下时区

$data = file_get_contents('php://input');//接收原始数据;

//file_put_contents('./wxmsg.log',$data."\r\n",FILE_APPEND);//记录接收消息log

$rec_arr = json_decode($data,true);//把接收的json转为数组

$this->checkAuthorization();//检测通信鉴权，并维护其值

// file_put_contents("resp.txt",'rec_arr-----'.json_encode($data,true).PHP_EOL, FILE_APPEND);

echo json_encode($this->response($rec_arr));

}

/**

public function remote(){

header("Content-type: text/html; charset=utf-8");

date_default_timezone_set("PRC");//设置下时区

// file_put_contents("resp.txt",'进入remote'.PHP_EOL, FILE_APPEND);

$param = [//若想使用同步处理，也就是你接收完事件要如何处理，那么你就要完善下面这个数组

"event" => isset($_REQUEST['event']) ? trim($_REQUEST['event']) : "SendTextMsg",

"robot_wxid" => isset($_REQUEST['robot_wxid']) ? trim($_REQUEST['robot_wxid']) : 'wxid_rqn31uwmjug922',//wxid_6mkmsto8tyvf52 wxid_5hxa04j4z6pg22

"group_wxid" => isset($_REQUEST['group_wxid']) ? trim($_REQUEST['group_wxid']) : '18221469840@chatroom',

"member_wxid" => isset($_REQUEST['member_wxid']) ? trim($_REQUEST['member_wxid']) : '',

"member_name" => isset($_REQUEST['member_name']) ? trim($_REQUEST['member_name']) : '',

"to_wxid" => isset($_REQUEST['to_wxid']) ? trim($_REQUEST['to_wxid']) : '18221469840@chatroom',

"msg" => isset($_REQUEST['msg']) ? trim($_REQUEST['msg']) : "你好啊！"

];

echo json_encode($this->request($param));

}

/**

public function down()

{

ob_clean();

$filepath = $_REQUEST['filepath']??'./favicon.ico';

if (!file_exists($filepath)) {

exit(json_encode(['success'=>false,'message'=>'file not found!']));

}

$fp = fopen($filepath, "r");

$filesize = filesize($filepath);

header("Content-type:application/octet-stream");

header("Accept-Ranges:bytes");

header("Accept-Length:" . $filesize);

header("Content-Disposition: attachment; filename=" . basename($filepath));

$buffer = 1024;

$buffer_count = 0;

while (!feof($fp) && $filesize - $buffer_count > 0) {

$data = fread($fp, $buffer);

$buffer_count += $buffer;

echo $data;

}

fclose($fp);

}

/**

public function request($param){

if(is_string($param['msg']))

$param['msg'] = $this->formatEmoji($param['msg']);//处理emoji

//处理完事件返回要怎么做

$headers = [

'Content-Type:application/json;charset=utf-8',

];

if($this->authorization)

$headers[] = "Authorization:{$this->authorization}";

$json = json_encode($param);

echo $json;

return json_decode($this->sendHttp($json,null,$headers),true);

}

/**

public function response($request){

$response = ["event" => ""];//event空时，机器人不处理消息

file_put_contents("resp.txt",'events----'.$request['event'].PHP_EOL, FILE_APPEND);

$functions = $this->events[$request['event']];

if(empty($functions))//若没处理方法，直接返回空数据告知机器人不处理即可！

return $response;

foreach ($functions as $func => $is_on){

if($is_on){

$response = call_user_func([$this,$func],$request);

if($response !== false)

break;//只要一个成功就跳出循环

}

}

//处理完事件返回要怎么做

return $response;

}

//复读机功能

public function replay_text($request){

$msg = trim($request['msg']);

if($this->startWith($msg,'复读')){

file_put_contents("resp.txt",'replay_text----'.'走了'.PHP_EOL, FILE_APPEND);

return SendTextMsg($request,$msg);

}

return false;

}

//发图功能

public function replay_img($request){

$msg = trim($request['msg']);

if($this->startWith($msg,'图')){

return SendImageMsg($request,'http://pic.5tu.cn/uploads/allimg/1901/pic_5tu_big_201901170106566711.jpg','pic_5tu_big_201901170106566711.jpg');

}

return false;

}

//发送视频功能

public function replay_video($request){

$msg = trim($request['msg']);

if($this->startWith($msg,'视频')){

return SendVideoMsg($request,'https://v9.douyinvod.com/8ae942678610b53075cefe549a2c314a/61cad328/video/tos/cn/tos-cn-ve-15-alinc2/bd191ead1b9f48e89f7570dd6c12f7a6/?a=1128&br=2433&bt=2433&cd=0%7C0%7C0&ch=96&cr=0&cs=0&cv=1&dr=0&ds=6&er=&ft=YbbdSWWFBLwqO543agD12UZ13_3w&l=202112281604160102121012333A00D68F&lr=all&mime_type=video_mp4&net=0&pl=0&qs=0&rc=MzxqbTo6ZmozOjMzNGkzM0ApM2llOWUzZWU3N2c3PDVoOmcpaHV2fWVuZDFwekAvXjEucjQwZi1gLS1kLTBzcy5eNWM2X2EtXzZgMjZiMC46Y29zYlxmK2BtYmJeYA%3D%3D&vl=&vr=','6.mp4');

}

return false;

}

//发送文件功能

public function replay_file_msg($request){

$msg = trim($request['msg']);

if($this->startWith($msg,'文件')){

return SendFileMsg($request,'http://pic.5tu.cn/uploads/allimg/1901/pic_5tu_big_201901170106566711.jpg','111.jpg');

}

return false;

}

//发送动态表情

public function replay_emjoy_msg($request){

$msg = trim($request['msg']);

if($this->startWith($msg,'表情')){

return SendEmojiMsg($request,'https://qq.yh31.com/tp/qw/202111191551197602.gif','202111191551197602.gif');

}

return false;

}

//发送分享消息功能

public function replay_link_msg($request){

$msg = trim($request['msg']);

if($this->startWith($msg,'分享')){

$title='测试标题';

$text='测试描述';

$target_url='http://www.baidu.com';

$pic_url='https://www.baidu.com/img/flexible/logo/pc/result.png';

$icon_url='https://img0.baidu.com/it/u=2294861089,3210317650&fm=253&fmt=auto&app=120&f=JPEG?w=200&h=200';

return SendLinkMsg($request,$title,$text,$target_url,$pic_url,$icon_url);

}

return false;

}

//发送分享音乐功能

public function replay_music_msg($request){

$msg = trim($request['msg']);

if($this->startWith($msg,'音乐')){

$name='我要你';

return SendMusicMsg($request,$name);

}

return false;

}

public function music($request){

$key = ['点歌','我想听','来一首'];

$msg = trim($request['msg']);

foreach ($key as $v){

if($this->startWith($msg,$v)){

$name = trim(str_replace($v,'',$msg));//把 key的前缀词替换为空

return [

"event" => "SendMusicMsg",

"robot_wxid" => $request['robot_wxid'],

"to_wxid" => $request['from_wxid'] ? $request['from_wxid'] : $request['final_from_wxid'],

"member_wxid" => '',

"member_name" => '',

"group_wxid" => '',

"msg" => ['name'=>$name,'type'=>0],

];

}

}

return false;

}

public function douyin($request){

$key = ['抖音','抖音视频','抖'];

$msg = trim($request['msg']);

foreach ($key as $v){

if($this->startWith($msg,$v)){

$dou['link'] = trim(str_replace($v,'',$msg));//把用户发的消息截取为url

$dou_json = $this->sendHttp(http_build_query($dou),'http://qsy.988g.cn/ajax/analyze.php');

//file_put_contents('./dou_json.txt',$dou_json);

$dou_arr = json_decode($dou_json,true);

//var_dump($dou_arr['data']['cover']);

//$v_file = file_get_contents('/tmp/dou/'.basename($dou_arr['data']['downurl']),$dou_arr['data']['downurl']);

$link = [

'title' => $dou_arr['data']['voidename'],

'text' => $dou_arr['data']['voidename'],

'target_url' => $dou_arr['data']['downurl'],

'pic_url' => $dou_arr['data']['cover'],

'icon_url' => $dou_arr['data']['cover'],

];

//发送分享链接 robot_wxid, to_wxid(群/好友), msg(title, text, target_url, pic_url, icon_url)

return [

"event" => "SendLinkMsg",

"robot_wxid" => $request['robot_wxid'],

"to_wxid" => $request['from_wxid'] ? $request['from_wxid'] : $request['final_from_wxid'],

"member_wxid" => '',

"member_name" => '',

"group_wxid" => '',

"msg" => $link,

];

}

}

return false;

}

/**

public function startWith($str,$pattern) {

return strpos($str,$pattern) === 0 ? true : false;

}

/**

public function formatEmoji($str){

$strEncode = '';

$length = mb_strlen($str,'utf-8');

for ($i=0; $i < $length; $i++) {

$_tmpStr = mb_substr($str,$i,1,'utf-8');

if(strlen($_tmpStr) >= 4){

$strEncode .= '[@emoji='.trim(json_encode($_tmpStr),'"').']';

}else{

$strEncode .= $_tmpStr;

}

}

return $strEncode;

}

/**

public function sendHttp($params, $url = null, $headers = null, $method = 'post', $timeout = 3)

{

$url = $url ? $url : $this->host.':'.$this->port;

$curl = curl_init();

if ('get' == strtolower($method)) {//以GET方式发送请求

curl_setopt($curl, CURLOPT_URL, "{$url}?{$params}");

} else {//以POST方式发送请求

curl_setopt($curl, CURLOPT_URL, $url);

curl_setopt($curl, CURLOPT_POST, 1);//post提交方式

curl_setopt($curl, CURLOPT_POSTFIELDS, $params);//设置传送的参数

}

/* $headers 格式

if(!empty($headers))

curl_setopt($curl, CURLOPT_HTTPHEADER, $headers);

curl_setopt($curl, CURLOPT_HEADER, false);//是否打印服务器返回的header

curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);//要求结果为字符串且输出到屏幕上

curl_setopt($curl, CURLOPT_CONNECTTIMEOUT, $timeout);//设置等待时间

$res = curl_exec($curl);//运行curl

$err = curl_error($curl);

if (false === $res || !empty($err)) {

$Errno = curl_errno($curl);

$Info = curl_getinfo($curl);

curl_close($curl);

print_r($Info);

return $err. ' result: ' . $res . 'error_msg: '.$Errno;

}

curl_close($curl);//关闭curl

return $res;

}

/**

private function getHeaders() {

$headers = [];

if (!function_exists('getallheaders')) {

foreach ($_SERVER as $name => $value) {

if (substr($name, 0, 5) == 'HTTP_') {

$headers[str_replace(' ', '-',

ucwords(strtolower(str_replace('_', ' ', substr($name, 5)))))] = $value;

}

}

}else{

$headers = getallheaders();

}

return $headers;

}

/**

private function setAuthorization($authorization = ''){

file_put_contents($this->authorization_file,$authorization);

$this->authorization = $authorization;

return $this->authorization;

}

/**

private function getAuthorization(){

$this->authorization = file_get_contents($this->authorization_file) ?:'';

return $this->authorization;

}

/**

private function checkAuthorization(){

$headers = $this->getHeaders();

// file_put_contents("resp.txt",json_encode($headers).PHP_EOL, FILE_APPEND);

if(!empty($headers['Authorization']) && $headers['Authorization'] != $this->getAuthorization())

return $this->setAuthorization($headers['Authorization'] ?: '');

}