kaifa/premium
Template
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
Files
ac01456284f42069842a71a4cab6b4979479e8fb
premium/app/controller/api/Telegram.php
T
root ac01456284 修复不扣余额
2025-07-07 07:57:02 +00:00

860 lines
43 KiB
PHP
Executable File
Raw Blame History

<?php
namespace app\controller\api;
use think\facade\Cache;
use laytp\controller\Api;
use think\facade\Log;
use think\facade\Db;
use app\service\Telegram as Telegrambot;
use think\facade\Request;
use app\service\Customer;
/**
* @ApiInternal ()
*/
class Telegram extends Api
{
public $noNeedLogin = ['callback', 'setwebhook', 'task','tijiao','billusdt', 'apicallback', 'admincallback'];
public function send()
{
$userlist = Db::name('push')->limit(5)->select();
foreach ($userlist as $value) {
$Telegram = new Telegrambot($value['botkey']);
$Telegram->sendMessage($value['userid'], $value['text']);
Db::name('push')->where('id', $value['id'])->delete();
}
}
public function tijiao(){
$Customer=new Customer();
// $reqx = $Customer->submitkt('384', '0772ce075192dca13187ad2823d87cab','8032909529',time(), 15, '@zf789', 0, 'https://premium.konline.top/');
//var_dump("222222",$reqx);
}
public function billusdt(){
//查询所有机器人的地址
$addinfo_all = Db::name("admin_bot")->cache(120)->whereNull('delete_time')->select();
$xiayige=Cache::get("sxiyigejuhu");
if($xiayige==null){
$xiayige=0;
}
if(empty($addinfo_all[$xiayige])){
$xiayige=-1;
}else{
$valuex=$addinfo_all[$xiayige];
}
Cache::set("sxiyigejuhu",$xiayige+1,200);
if(!empty($valuex)){
$ym= $this->getbill($valuex['trxadd']);
//var_dump($valuex['trxadd'],$ym);
foreach ($ym as $key => $value) {
// code...
$transaction_id=$value['transaction_id'];
$timestamp = $value['block_ts'] / 1000;
$tokenName= isset($value['trigger_info']['method'])?$value['trigger_info']['method']:null;
if($tokenName=="transfer(address _to,uint256 _value)"){
//var_dump($value,$timestamp);
if($timestamp+600>time()){
if (!Db::name("k_chuliok")->where("transaction_id", $transaction_id)->find()) {
$addinfo =$valuex;
$money = $value['quant'] / 1000000;
$address = $value['to_address'];
$amount = $value['quant'] / 1000000;
$formAmount = number_format($money, 5, '.', '');
$transaction_id = $value['transaction_id'];
$from = $value['from_address'];
$to = $value['to_address'];
$timestamp = $value['block_ts'] / 1000;
$Telegram = new Telegrambot($addinfo['botkey']);
$Customer=new Customer();
//防止二次处理 涉及到钱
Db::name("k_chuliok")->insert(['transaction_id' => $transaction_id, "from" => $from, "to" => $to, "money" => $amount]);
//查询没有处理的订单
$order = Db::name("order")->where('botid', $addinfo['botid'])->where([["end_time", ">=", time()], ["trxadd", "=", $address], ["paymoney", "=", $formAmount], ["start", "=", 0]])->find();
if (!empty($order["id"])) {
Cache::set($order["order_no"], $order["order_no"], 320);
Db::name("order")->where("id", $order["id"])->update(array("start" => 1));
$xianshi = "USDT-TRC20";
$typeoto = "转入";
$dhshi = date("Y-m-d H:i:s ", $timestamp);
$bbaoadd = $from;
$usr = "https://tronscan.org/#/transaction/" . $transaction_id;
$tancan = isset($order["tancan"]) ? $order["tancan"] : "无";
$pushu = "交易成功
商品标题：<strong>" . $order["name"] . "</strong>
开通时间：<strong>" . $tancan . "</strong>
订单：<strong>" . $order["order_no"] . "</strong>
代币：<strong>" . $xianshi . "</strong>
时间：<strong>" . $dhshi . "</strong>
金额：<strong>" . $formAmount . "</strong> " . $xianshi . "
类型：" . $typeoto . "
提醒地址：<code>" . $address . "</code>
" . $typeoto . "地址：<code>" . $bbaoadd . "</code>" . "\r\n" . "\r\n" . '<a href="' . $usr . '">查询详细信息</a>';
$Telegram->sendMessage($addinfo['botad'], $pushu);
$info = Db::name("order")->where("id", $order["id"])->find();
$tmuid = Db::name("conf")->where("key", 'tmuid')->value('value');
$tmkey = Db::name("conf")->where("key", 'tmkey')->value('value');
$cycleMap = ['3' => '0', '6' => '1', '12' => '2'];
$mappedValue = $cycleMap[$info['tancan']] ?? '3';
//区分是批量 还是单个
if ($order['moth'] == "pkaihuiy") { //批量开通
$dakai = json_decode($order['username'], true);
foreach ($dakai as $key => $value) {
$reqx = $Customer->submitkt($tmuid, $tmkey, $addinfo['botid'],$info["order_no"], $order['danprice'], "@" . $value, $mappedValue, $addinfo['apiurl']);
if ($reqx['code'] == 0) {
$Telegram->sendMessage($addinfo['botad'], $reqx['msg'] . "\r\n" . "单号:<code>" . $order["order_no"] . "</code>" . "\r\n" . "用户名:<code>" . $order['username'] . "</code>" . "\r\n" . "开通时间:<code>" . $order['tancan'] . "</code>" . "\r\n" . "消费金额:<code>" . $order['money'] . "</code>" . "\r\n" . "处理方法:充值余额后手动提交给机器人代替客户开通");
//return true;
$Telegram->sendMessage($order['userid'], "订单提交成功！请联系客服,尽快处理！单号:<code>" . $order["order_no"] . "</code>");
} else {
$Telegram->sendMessage($order['userid'], $reqx['msg']);
//return true;
}
}
}
if ($order['moth'] == "huiyuangoumaai") { //单个会员开通
$reqx = $Customer->submitkt($tmuid, $tmkey, $addinfo['botid'],$info["order_no"], $info['money'], $info['username'], $mappedValue, $addinfo['apiurl']);
var_dump($reqx);
if ($reqx['code'] == 0) {
$Telegram->sendMessage($addinfo['botad'], $reqx['msg'] . "\r\n" . "单号:<code>" . $info["order_no"] . "</code>" . "\r\n" . "用户名:<code>" . $info['username'] . "</code>" . "\r\n" . "开通时间:<code>" . $info['tancan'] . "</code>" . "\r\n" . "消费金额:<code>" . $info['money'] . "</code>" . "\r\n" . "处理方法:充值余额后手动提交给机器人代替客户开通");
//return true;
$Telegram->sendMessage($info['userid'], "订单提交成功！请联系客服,尽快处理！单号:<code>" . $order["order_no"] . "</code>");
} else {
$Telegram->sendMessage($info['userid'], $reqx['msg']);
//return true;
}
}
//余额充值
if($order['moth'] == "yuepay"){
$Customer-> ChangeMoney($info['userid'], 'member', "+", $amount, $addinfo['botid'], "u充值");
$Telegram->sendMessage($info['userid'], "充值成功了 【".$amount."】");
var_dump($info,"1111");exit();
}
if (!empty($info['smessage_id'])) {
$Telegram->deleteMessage($info['userid'], $info['smessage_id']);
}
if (!empty($info['message_id'])) {
$Telegram->deleteMessage($info['userid'], $info['message_id']);
}
return json(['code' => 'success']);
} else {
$xianshi = "USDT-TRC20";
$typeoto = "转入";
$dhshi = date("Y-m-d H:i:s ", $timestamp);
$bbaoadd = $from;
$usr = "https://tronscan.org/#/transaction/" . $transaction_id;
$pushu = "发现新的交易
<strong>没有匹配到订单</strong>
代币：<strong>" . $xianshi . "</strong>
时间：<strong>" . $dhshi . "</strong>
金额：<strong>" . $formAmount . "</strong> " . $xianshi . "
类型：" . $typeoto . "
提醒地址：<code>" . $address . "</code>
" . $typeoto . "地址：<code>" . $bbaoadd . "</code>" . "\r\n" . "\r\n" . '<a href="' . $usr . '">查询详细信息</a>';
if ($amount > 0.9) {
//var_dump($pushu,$addinfo,$amount);
$Telegram->sendMessage($addinfo['botad'], $pushu, null, null, 'HTML', true);
}
}
// return json(['code'=>'success']);
var_dump("处理ok success");
//return $this->success("处理ok success");
}else{
var_dump("处理了 跳出");
break;
}
}else{
var_dump("跳过 超时".$valuex['trxadd']);
break;
}
}
// var_dump($transaction_id);
}
}
}
public function getbill($trxadd){
if(strlen($trxadd)<20){
return [];
}
$url= "https://apilist.tronscanapi.com/api/filter/trc20/transfers?limit=20&start=0&sort=-timestamp&count=true&filterTokenValue=0&relatedAddress=".$trxadd;
$ym=json_decode(file_get_contents($url),true) ;
$retdata=isset($ym['token_transfers'])?$ym['token_transfers']:null;
return $retdata;
}
public function curl_get($url, $data = [])
{
// 处理get数据
if (!empty($data)) {
$url = $url . '?' . http_build_query($data);
}
$curl = curl_init();
curl_setopt($curl, CURLOPT_URL, $url);
curl_setopt($curl, CURLOPT_HEADER, false);
curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);//这个是重点。
$result = curl_exec($curl);
curl_close($curl);
return $result;
}
public function admincallback()
{
var_dump('success');exit;
$data = $this->request->only(['to', 'from', 'money', 'hash', 'method', 'contract_address', 'paytype', 'timestamp']);
if ($data['contract_address'] == "TR7NHqjeKQxGTCi8q8ZY4pL8otSzgjLj6t") {
if ($data['method'] == "transfer(address _to,uint256 _value)") {
if ($data['paytype'] == "in") {
$money = $data['money'] / 1000000;
$address = $data['to'];
$amount = $data['money'] / 1000000;
$formAmount = number_format($money, 5, '.', '');
$transaction_id = $data['hash'];
$from = $data['from'];
$to = $data['to'];
$timestamp = $data['timestamp'] / 1000;
//通过地址获取到机器人的信息
$addinfo = Db::name("admin_bot")->where('trxadd', $address)->find();
$Telegram = new Telegrambot($addinfo['botkey']);
$Customer=new Customer();
if (!empty($addinfo['trxadd'])) {
if (!Db::name("k_chuliok")->where("transaction_id", $transaction_id)->find()) {
//防止二次处理 涉及到钱
Db::name("k_chuliok")->insert(['transaction_id' => $transaction_id, "from" => $from, "to" => $to, "money" => $amount]);
//查询没有处理的订单
$order = Db::name("order")->where('botid', $addinfo['botid'])->where([["end_time", ">=", time()], ["trxadd", "=", $address], ["paymoney", "=", $formAmount], ["start", "=", 0]])->find();
// var_dump($order,$formAmount);
if (!empty($order["id"])) {
Cache::set($order["order_no"], $order["order_no"], 320);
Db::name("order")->where("id", $order["id"])->update(array("start" => 1));
$xianshi = "USDT-TRC20";
$typeoto = "转入";
$dhshi = date("Y-m-d H:i:s ", $timestamp);
$bbaoadd = $data['from'];
$usr = "https://tronscan.org/#/transaction/" . $data['hash'];
$tancan = isset($order["tancan"]) ? $order["tancan"] : "无";
$pushu = "交易成功
商品标题：<strong>" . $order["name"] . "</strong>
开通时间：<strong>" . $tancan . "</strong>
订单：<strong>" . $order["order_no"] . "</strong>
代币：<strong>" . $xianshi . "</strong>
时间：<strong>" . $dhshi . "</strong>
金额：<strong>" . $formAmount . "</strong> " . $xianshi . "
类型：" . $typeoto . "
提醒地址：<code>" . $address . "</code>
" . $typeoto . "地址：<code>" . $bbaoadd . "</code>" . "\r\n" . "\r\n" . '<a href="' . $usr . '">查询详细信息</a>';
$Telegram->sendMessage($addinfo['botad'], $pushu);
$info = Db::name("order")->where("id", $order["id"])->find();
$tmuid = Db::name("conf")->where("key", 'tmuid')->value('value');
$tmkey = Db::name("conf")->where("key", 'tmkey')->value('value');
$cycleMap = ['3' => '0', '6' => '1', '12' => '2'];
$mappedValue = $cycleMap[$info['tancan']] ?? '3';
//区分是批量 还是单个
if ($order['moth'] == "pkaihuiy") { //批量开通
$dakai = json_decode($order['username'], true);
foreach ($dakai as $key => $value) {
$reqx = $Customer->submitkt($tmuid, $tmkey, $addinfo['botid'],$info["order_no"], $order['danprice'], "@" . $value, $mappedValue, $addinfo['apiurl']);
if ($reqx['code'] == 0) {
$Telegram->sendMessage($addinfo['botad'], $reqx['msg'] . "\r\n" . "单号:<code>" . $order["order_no"] . "</code>" . "\r\n" . "用户名:<code>" . $order['username'] . "</code>" . "\r\n" . "开通时间:<code>" . $order['tancan'] . "</code>" . "\r\n" . "消费金额:<code>" . $order['money'] . "</code>" . "\r\n" . "处理方法:充值余额后手动提交给机器人代替客户开通");
//return true;
$Telegram->sendMessage($order['userid'], "订单提交成功！请联系客服,尽快处理！单号:<code>" . $order["order_no"] . "</code>");
} else {
$Telegram->sendMessage($order['userid'], $reqx['msg']);
//return true;
}
}
}
if ($order['moth'] == "huiyuangoumaai") { //单个会员开通
$reqx = $Customer->submitkt($tmuid, $tmkey, $addinfo['botid'],$info["order_no"], $info['money'], $info['username'], $mappedValue, $addinfo['apiurl']);
//var_dump($reqx);
if ($reqx['code'] == 0) {
$Telegram->sendMessage($addinfo['botad'], $reqx['msg'] . "\r\n" . "单号:<code>" . $info["order_no"] . "</code>" . "\r\n" . "用户名:<code>" . $info['username'] . "</code>" . "\r\n" . "开通时间:<code>" . $info['tancan'] . "</code>" . "\r\n" . "消费金额:<code>" . $info['money'] . "</code>" . "\r\n" . "处理方法:充值余额后手动提交给机器人代替客户开通");
//return true;
$Telegram->sendMessage($info['userid'], "订单提交成功！请联系客服,尽快处理！单号:<code>" . $order["order_no"] . "</code>");
} else {
$Telegram->sendMessage($info['userid'], $reqx['msg']);
//return true;
}
}
//余额充值
if($order['moth'] == "yuepay"){
$Customer-> ChangeMoney($info['userid'], 'member', "+", $amount, $addinfo['botid'], "u充值");
$Telegram->sendMessage($info['userid'], "充值成功了 【".$amount."】");
var_dump($info,"1111");exit();
}
if (!empty($info['smessage_id'])) {
$Telegram->deleteMessage($info['userid'], $info['smessage_id']);
}
if (!empty($info['message_id'])) {
$Telegram->deleteMessage($info['userid'], $info['message_id']);
}
return json(['code' => 'success']);
} else {
$xianshi = "USDT-TRC20";
$typeoto = "转入";
$dhshi = date("Y-m-d H:i:s ", $timestamp);
$bbaoadd = $data['from'];
$usr = "https://tronscan.org/#/transaction/" . $data['hash'];
$pushu = "发现新的交易
<strong>没有匹配到订单</strong>
代币：<strong>" . $xianshi . "</strong>
时间：<strong>" . $dhshi . "</strong>
金额：<strong>" . $formAmount . "</strong> " . $xianshi . "
类型：" . $typeoto . "
提醒地址：<code>" . $address . "</code>
" . $typeoto . "地址：<code>" . $bbaoadd . "</code>" . "\r\n" . "\r\n" . '<a href="' . $usr . '">查询详细信息</a>';
if ($amount > 0.9) {
//var_dump($pushu,$addinfo,$amount);
$Telegram->sendMessage($addinfo['botad'], $pushu, null, null, 'HTML', true);
}
}
// return json(['code'=>'success']);
return $this->success("处理ok success");
}else{
return $this->success("已被处理 success");
}
} else {
return $this->success('ok success 地址没有绑定机器人');
}
}
}
}
//var_dump($data);
}
public function apicallback()
{
$data = $this->request->only(['uid', 'umoney', 'start', 'username', 'orderid']);
$tmuid = Db::name("conf")->where("key", 'tmuid')->value('value');
if ($tmuid != $data['uid']) {
return $this->error('uid 错误');
}
if ($data['start'] == 2) {
//验证单号
$odder = Db::name('ok_order')->where("order_no", $data['orderid'])->find();
if (empty($odder['order_no'])) {
return $this->error('订单不存在');
}
if ($odder['call'] == 1) {
return $this->error('订单已处理');
}
$odder = Db::name('order')->where("order_no", $odder['sn'])->find();
//更新订单状态 发送用户通知
$botid = $odder['botid'];
//查询机器人
$botinfo = Db::name("admin_bot")->cache(60)->where("botid", $botid)->whereNull('delete_time')->find();
$Telegram = new Telegrambot($botinfo['botkey']);
$msg = "会员开通成功了" . "\r\n" . "开通用户名:<strong>" . $data['username'] . "</strong>" . "\r\n" . "开通时间: <strong>" . $odder['tancan'] . "</strong>" . "\r\n" . "订单单号:<strong>" . $odder['order_no'] . "</strong>" . "\r\n" . "感谢您的支持！";
// var_dump($msg);exit();
$Telegram->sendMessage($odder['userid'], $msg);
//通知机器人管理员一份儿
if($odder['userid']!=$botinfo['botad']){
$Telegram->sendMessage($botinfo['botad'], "开通成功通知"."\r\n". "开通用户名:<strong>" . $data['username'] . "</strong>" . "\r\n" . "开通时间: <strong>" . $odder['tancan'] . "</strong>" . "\r\n" . "订单单号:<strong>" . $odder['order_no'] . "</strong>" );
}
Db::name('ok_order')->where("order_no", $data['orderid'])->update(['call' => 1]);
return $this->success('ok');
}
if ($data['start'] == 4) {
//退单
$odder = Db::name('ok_order')->where("order_no", $data['orderid'])->find();
if (empty($odder['order_no'])) {
return $this->error('订单不存在');
}
if ($odder['call'] == 1) {
return $this->error('订单已处理');
}
$botid = $odder['botid'];
$odder = Db::name('order')->where("order_no", $odder['sn'])->find();
//查询机器人
$botinfo = Db::name("admin_bot")->where("botid", $botid)->find();
$Telegram = new Telegrambot($botinfo['botkey']);
$msg = "会员开通失败了" . "\r\n" . "开通用户名:<strong>" . $data['username'] . "</strong>" . "\r\n" . "开通时间: <strong>" . $odder['tancan'] . "</strong>" . "\r\n" . "订单单号:<strong>" . $odder['order_no'] . "</strong>" . "\r\n" . "消费金额:" . $odder['paymoney'] . "[已退回余额]" . "\r\n" . "如需开通请联系客服手动开通";
$Customer=new Customer();
$Customer-> ChangeMoney($odder['userid'], 'member', "+", $odder['money'], $botid, "退款" . $data['username']);
$Telegram->sendMessage($odder['userid'], $msg);
Db::name('ok_order')->where("order_no", $data['orderid'])->update(['call' => 1]);
return $this->success('ok');
}
// var_dump($odder,$data,"222");
}
public function task()
{
$systemadd = Db::name("conf")->cache(600)->where("key", 'system')->value('value');
$conftask = cache::get("conftask");
if (empty($conftask)) {
if (!empty($systemadd)) {
if (preg_match('/^T(?=.*[A-Za-z])(?=.*\d)[A-Za-z\d]+$/', $systemadd)) {
//var_dump("4444","地址合规");
cache::set("conftask", $systemadd, 10);
$this->Queryamountchange($systemadd);
}
}
}
$this->send();
}
public function Queryamountchange($trxadd)
{
$curl = curl_init();
curl_setopt_array($curl, [
CURLOPT_URL => "https://api.trongrid.io/v1/accounts/" . $trxadd . "/transactions/trc20?only_to=true&limit=10&contract_address=TR7NHqjeKQxGTCi8q8ZY4pL8otSzgjLj6t",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "GET",
CURLOPT_HTTPHEADER => [
"Accept: application/json"
],
]);
$response = curl_exec($curl);
$err = curl_error($curl);
curl_close($curl);
if ($err) {
echo "cURL Error #:" . $err;
} else {
$hui = json_decode($response, true);
}
foreach ($hui["data"] as $key => $value) {
// var_dump($value);
$hash = $value['transaction_id'];
$timestamp = $value['block_timestamp'] / 1000 + 200;
if ($timestamp > time()) {
// 处理过的 写入缓存 过期即可 不处理
$chuliguo = Cache::get("chuliguodehaxi" . $hash);
if (!$chuliguo) {
$owner_address = $value['from'];
$to_address = $value['to'];
$amount = $value['value'] / 1000000;
if ($amount > 1) {
//查询 用户地址 对应的用户
$hot = Db::name("admin_bot")->where(['trxadd' => $owner_address])->find();
if ($value['type'] == "Transfer") {
if (isset($hot["id"])) {
$Customer=new Customer();
$Customer-> ChangeMoney($hot['botid'], 'admin', "+", $amount, "", "u充值");
Cache::set("chuliguodehaxi" . $hash, 1, 300);
$system = Db::name("conf")->where("key", 'botkey')->value('value');
$masterid = Db::name("conf")->where("key", 'masterid')->value('value');
if (!empty($system)) {
if (!empty($masterid)) {
$Telegram = new Telegrambot($system);
$msg = "充值成功" . "\r\n" . "来源:<code>" . $owner_address . "</code>" . "\r\n" . "金额:<code>" . $amount . "</code>" ."\r\n". "bot昵称:<code>" . $hot['name'] . "</code>" ."\r\n". "botbotuser:<code>" . $hot['botuser'] . "</code>" . "\r\n" . "请注意查看";
$Telegram->sendMessage($masterid, $msg);
}
}
} else {
//未找到用户 充值失败
$system = Db::name("conf")->where("key", 'botkey')->value('value');
$masterid = Db::name("conf")->where("key", 'masterid')->value('value');
if (!empty($system)) {
if (!empty($masterid)) {
$Telegram = new Telegrambot($system);
$msg = "充值订单为匹配" . "\r\n" . "来源:<code>" . $owner_address . "</code>" . "\r\n" . "金额:<code>" . $amount . "</code>" . "\r\n" . "请注意查看";
$Telegram->sendMessage($masterid, $msg);
}
}
}
}
// var_dump($owner_address,$to_address,$amount,$timestamp,$hash,$hot);
}
} else {
echo "已处理";
}
}
// code...
}
}
public function callback()
{
Log::record('测试日志信息');
$botid = Request::param("botid");
$parseMessage = $this->parseMessage();
//var_dump($parseMessage);
$className = 'app\service\plugins\Premium';
$botinfo = Db::name("admin_bot")->cache(120)->where("botid", $botid)->whereNull('delete_time')->find();
if(!empty($botinfo)){
$class = new $className($parseMessage['data'], $botid);
if (!empty($parseMessage["func"])) {
echo $parseMessage["func"];
call_user_func_array(array($class, "init"), $parseMessage["intparam"]);
if (method_exists($class, $parseMessage["func"])) {
call_user_func_array(array($class, $parseMessage["func"]), $parseMessage["param"]);
}
}
}else{
return $this->error('bot error');
}
// var_dump($parseMessage);
return $this->success('返回成功', ['action' => 'callback']);
}
public function setwebhook()
{
return $this->success('返回成功', ['action' => 'setwebhook']);
}
public function parseMessage()
{
$data = json_decode(file_get_contents("php://input"), true);
Log::record(Request::url() . file_get_contents("php://input") . "\n", FILE_APPEND);
if (isset($data['message'])) {
if (isset($data['message']['text'])) {
if (isset($data['message']['reply_to_message'])) {
$data['message']['chat']['reply_to_message'] = $data['message']['reply_to_message'];
}
/** 艾特处理 */
if (isset($data['message']['entities'])) {
foreach ($data['message']['entities'] as $entities) {
if ($entities['type'] == 'text_mention') {
$mentionUserId = $entities['user']['id'];
$mentionUserName = $entities['user']['first_name'];
}
if ($entities['type'] == 'mention') {
$tmp = mb_substr($data['message']['text'], $entities['offset'] + 1, $entities['length'], "utf-8");
$mentionUserId = $tmp;
$mentionUserName = $tmp;
}
$mentionUserId = isset($mentionUserId) ? $mentionUserId : "";
$mentionUserName = isset($mentionUserName) ? $mentionUserName : "";
$data['message']['at_array'][] = ['id' => $mentionUserId, 'name' => $mentionUserName];
$data['message']['at_ids'][] = $mentionUserId;
}
}
if ($data['message']['text'][0] == '/') {
$data['message']['text'] = str_replace("\n", " ", $data['message']['text']);
$messageExplode = explode(' ', $data['message']['text']);
$commandExplode = explode('@', $messageExplode[0]);
if (isset($commandExplode[1]) && $commandExplode[1] != BOTNAME)
exit();
$func = 'command';
$param = [
$commandExplode[0],
array(),
$data['message']['message_id'],
$data['message']['from'],
$data['message']['chat'],
$data['message']['date'],
];
$initParam = [
$func,
$data['message']['from'],
$data['message']['chat'],
$data['message']['date'],
];
if (isset($messageExplode[1])) {
$param[1] = array_slice($messageExplode, 1);
}
} else {
if (isset($data['message']) && !isset($data['message']['reply_to_message'])) {
$func = 'message';
$param = [
$data['message']['text'],
$data['message']['message_id'],
$data['message']['from'],
$data['message']['chat'],
$data['message']['date'],
];
$initParam = [
$func,
$data['message']['from'],
$data['message']['chat'],
$data['message']['date'],
];
} else {
$func = 'reply_message';
$param = [
$data['message']['text'],
$data['message']['message_id'],
$data['message']['reply_to_message']['text'],
$data['message']['reply_to_message']['message_id'],
$data['message']['reply_to_message']['date'],
$data['message']['from'],
$data['message']['chat'],
$data['message']['reply_to_message']['from']['is_bot'],
];
$initParam = [
$func,
$data['message']['from'],
$data['message']['chat'],
$data['message']['date'],
];
}
}
} else if (isset($data['message']['new_chat_title'])) {
$func = 'new_chat_title';
$param = [
$data['message']['new_chat_title'],
$data['message']['message_id'],
$data['message']['from'],
$data['message']['chat'],
$data['message']['date'],
];
$initParam = [
$func,
$data['message']['from'],
$data['message']['chat'],
$data['message']['date'],
];
} else if (isset($data['message']['new_chat_member'])) {
$func = 'new_member';
$param = [
$data['message']['new_chat_member'],
$data['message']['message_id'],
$data['message']['from'],
$data['message']['chat'],
$data['message']['date'],
];
$initParam = [
$func,
$data['message']['from'],
$data['message']['chat'],
$data['message']['date'],
];
} else if (isset($data['message']['left_chat_member'])) {
$func = 'left_member';
$param = [
$data['message']['left_chat_member'],
$data['message']['message_id'],
$data['message']['from'],
$data['message']['chat'],
$data['message']['date'],
];
$initParam = [
$func,
$data['message']['from'],
$data['message']['chat'],
$data['message']['date'],
];
} else if (isset($data['message']['sticker'])) {
$func = 'sticker';
$param = [
$data['message']['sticker'],
$data['message']['message_id'],
$data['message']['from'],
$data['message']['chat'],
$data['message']['date'],
];
$initParam = [
$func,
$data['message']['from'],
$data['message']['chat'],
$data['message']['date'],
];
} else if (isset($data['message']['photo'])) {
$caption = '';
if (isset($data['message']['caption'])) {
$caption = $data['message']['caption'];
}
$func = 'photo';
$param = [
$data['message']['photo'],
$caption,
$data['message']['message_id'],
$data['message']['from'],
$data['message']['chat'],
$data['message']['date'],
];
$initParam = [
$func,
$data['message']['from'],
$data['message']['chat'],
$data['message']['date'],
];
} else if (isset($data['message']['document'])) {
$caption = '';
if (isset($data['message']['caption'])) {
$caption = $data['message']['caption'];
}
$func = 'document';
$param = [
$data['message']['document'],
$caption,
$data['message']['message_id'],
$data['message']['from'],
$data['message']['chat'],
$data['message']['date'],
];
$initParam = [
$func,
$data['message']['from'],
$data['message']['chat'],
$data['message']['date'],
];
}
} else if (isset($data['callback_query'])) {
if (isset($data['callback_query']['data'])) {
//['callback_query']['chat_instance']
$func = 'callback_query';
$param = [
$data['callback_query']['data'],
$data['callback_query']['id'],
$data['callback_query']['from'],
$data['callback_query']['message']['message_id'],
$data['callback_query']['message']['from'],
$data['callback_query']['message']['chat'],
$data['callback_query']['message']['date']
];
$initParam = [
$func,
$data['callback_query']['from'],
$data['callback_query']['message']['chat'],
$data['callback_query']['message']['date']
];
} else if (isset($data['callback_query']['game_short_name'])) {
$func = 'callback_game';
$param = [
$data['callback_query']['game_short_name'],
$data['callback_query']['id'],
$data['callback_query']['from']
];
$initParam = [
$func,
$data['callback_query']['from'],
$data['callback_query']['from'],
time()
];
}
} else if (isset($data['inline_query'])) {
$func = 'inline_query';
$param = [
$data['inline_query']['query'],
$data['inline_query']['offset'],
$data['inline_query']['id'],
$data['inline_query']['from']
];
$initParam = [
$func,
$data['inline_query']['from'],
$data['inline_query']['from'],
time()
];
} else if (isset($data['business_message'])) {
if (isset($data['business_message']['text'])) {
$data['business_message']['from']['business_connection_id'] = $data['business_message']['business_connection_id'];
if ($data['business_message']['text'][0] == '/') {
$data['business_message']['text'] = str_replace("\n", " ", $data['business_message']['text']);
$messageExplode = explode(' ', $data['business_message']['text']);
$commandExplode = explode('@', $messageExplode[0]);
if (isset($commandExplode[1]) && $commandExplode[1] != BOTNAME)
exit();
$func = 'qiye_command';
$param = [
$commandExplode[0],
array(),
$data['business_message']['message_id'],
$data['business_message']['from'],
$data['business_message']['chat'],
$data['business_message']['date'],
];
$initParam = [
$func,
$data['business_message']['from'],
$data['business_message']['chat'],
$data['business_message']['date'],
];
// var_dump($param,$initParam);
if (isset($messageExplode[1])) {
$param[1] = array_slice($messageExplode, 1);
}
} else {
if (isset($data['business_message']) && !isset($data['message']['reply_to_message'])) {
$func = 'business_message';
$param = [
$data['business_message']['text'],
$data['business_message']['message_id'],
$data['business_message']['from'],
$data['business_message']['chat'],
$data['business_message']['date'],
];
$initParam = [
$func,
$data['business_message']['from'],
$data['business_message']['chat'],
$data['business_message']['date'],
];
}
}
}
}
if (isset($func)) {
return array("func" => $func, "param" => $param, "intparam" => $initParam, "data" => $data);
} else {
return array("func" => null, "param" => null, "intparam" => null, "data" => null);
}
}
}
Reference in New Issue View Git Blame Copy Permalink