<?phpnamespace app\web\controller;
use app\model\Member;
use think\Controller;
use Telegram\Bot\Api;
use think\Db;
use think\Log;
use app\utils\CacheUtil;
class TelegramController extends Controller
{
    // 机器人名字  mall_rebate1_bot
    const TG_TOKEN = 'xxxx';

    private $chat_id; //群ID
    private $message_text;//群消息内容


    /**
     * 错误代码
     * @var int
     */
    protected $errorCode;

    /**
     * 错误信息
     * @var string
     */
    protected $errorMessage = '';


    /**
     * 返回错误代码
     * @return int
     */
    public function getErrorCode()
    {
        return $this->errorCode;
    }

    /**
     * 返回错误信息
     * @return string
     */
    public function getErrorMessage()
    {
        return $this->errorMessage;
    }


    /**
     * 创建对话
     */
    public function createWebHook()
    {
        $telegram = new Api(self::TG_TOKEN);
        return $telegram->setWebhook(['url' => 'https://xxxx/listenWebHook']);
    }

    /**
     * 移除对话
     */
    public function removeWebHook()
    {
        $telegram = new Api(self::TG_TOKEN);
        return $telegram->removeWebhook();
    }

    /**
     * 监听对话
     */
    public function listenWebHook()
    {

        if (!$this->checkRequest()) {
            return false;
        }

        //  加彩金的方法
        if (in_array($this->chat_id, ['-11', '-22'])) {
            $response_text = $this->transferIn();
            if ($response_text) {
                return $this->replayMessage($response_text);
            }
            return true;
        } else {//            return $this->replayMessage($this->chat_id);
        }

        return false;

    }

    private function transferIn()
    {
        //  使用空格做区分
        $arr = array_values(array_filter(explode(" ", $this->message_text)));
        if (count($arr) != 2) {
            return '格式有误';
        }

        $username = $arr[0];
        $userInfo = Member::getByUsername($username);
        if (!$userInfo) {
            return '用户不存在' . $username;
        }

       // 业务

        return  'success';

    }


    /**
     * 推送消息
     * @param $result
     * @return bool|\Telegram\Bot\Objects\Message
     * @throws \Telegram\Bot\Exceptions\TelegramSDKException
     */
    private function replayMessage($result)
    {
        $telegram = new Api(self::TG_TOKEN);
        try {
            return $telegram->sendMessage([
                'chat_id' => $this->chat_id, //  message.chat.id   这个id必须是消息发布的群，不然不能实现回复
                'text' => $result, //  回复内容
                'parse_mode' => 'HTML',
            ]);
        } catch (\Exception $exception) {
            $this->errorCode = -1;
            $this->errorMessage = $exception->getMessage(); // 一般来说都是 chat_id 有误
            return false;
        }
    }

    /**
     * 检查请求消息
     * @return bool
     */
    private function checkRequest()
    {
        $info = file_get_contents('php://input');
        $request = [];
        if (json_decode($info)) {
            $request = json_decode($info, 1);
        }//        Log::info('222 notify1 start data = ' . json_encode($info));

        // 1.检查数据格式  是否有 chat_id 和 caption
        if (!isset($request['message']['chat']['id'])) {
            $this->errorCode = -11;
            $this->errorMessage = 'chat id 不存在';
            return false;
        }
        if (!isset($request['message']['text'])) {
            $this->errorCode = -12;
            $this->errorMessage = 'text不存在';
            return false; // 这个不需要输出  不需要处理
        }

        if ($request['message']['from']['is_bot'] == true) {
            return true;//机器人发送的消息  不需要处理
        }

        // 群ID 也是chat_id
        $this->chat_id = $request['message']['chat']['id'];
        $this->message_text = trim($request['message']['text']); // 群消息

        //  有中文  表示是聊天信息
        preg_match('/^(\p{Han})/u', $this->message_text, $result);
        if ($result) {
            $this->errorCode = -3;
            $this->errorMessage = '中文聊天，不需要处理';
            return false; // 这条消息不发送给飞机群 所以是 false
        }

        return true;
    }}