|
|
@@ -0,0 +1,279 @@
|
|
|
+<?php
|
|
|
+/**
|
|
|
+ * Bark 推送
|
|
|
+ *
|
|
|
+ * @author mybsdc <[email protected]>
|
|
|
+ * @date 2021/11/3
|
|
|
+ * @time 11:18
|
|
|
+ */
|
|
|
+
|
|
|
+namespace Luolongfei\Libs\MessageServices;
|
|
|
+
|
|
|
+use GuzzleHttp\Client;
|
|
|
+use Luolongfei\Libs\Connector\MessageGateway;
|
|
|
+
|
|
|
+class Bark extends MessageGateway
|
|
|
+{
|
|
|
+ const TIMEOUT = 33;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @var string Bark Key
|
|
|
+ */
|
|
|
+ protected $barkKey;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @var string Bark 域名
|
|
|
+ */
|
|
|
+ protected $barkUrl;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @var integer|string 指定是否需要保存推送信息到历史记录，1 为保存，其他值为不保存。如果值为空字符串，则推送信息将按照 APP 内设置来决定是否保存
|
|
|
+ */
|
|
|
+ protected $isArchive;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @var string 指定推送消息分组，可在历史记录中按分组查看推送
|
|
|
+ */
|
|
|
+ protected $group;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 可选参数值
|
|
|
+ * active：不设置时的默认值，系统会立即亮屏显示通知
|
|
|
+ * timeSensitive：时效性通知，可在专注状态下显示通知
|
|
|
+ * passive：仅将通知添加到通知列表，不会亮屏提醒
|
|
|
+ *
|
|
|
+ * @var string 时效性通知
|
|
|
+ */
|
|
|
+ protected $level;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @var string 指定推送消息图标 (仅 iOS15 或以上支持）http://day.app/assets/images/avatar.jpg
|
|
|
+ */
|
|
|
+ protected $icon;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @var string 点击推送将跳转到url的地址（发送时，URL参数需要编码），GuzzleHttp 库会自动编码
|
|
|
+ */
|
|
|
+ protected $jumpUrl;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @var integer 携带参数 automaticallyCopy=1， 收到推送时，推送内容会自动复制到粘贴板（如发现不能自动复制，可尝试重启一下手机）
|
|
|
+ */
|
|
|
+ protected $automaticallyCopy = 1;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @var string 携带 copy 参数， 则上面两种复制操作，将只复制 copy 参数的值
|
|
|
+ */
|
|
|
+ protected $copy = 'https://my.freenom.com/domains.php?a=renewals';
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @var Client
|
|
|
+ */
|
|
|
+ protected $client;
|
|
|
+
|
|
|
+ public function __construct()
|
|
|
+ {
|
|
|
+ $this->barkKey = config('message.bark.bark_key');
|
|
|
+ $this->barkUrl = rtrim(config('message.bark.bark_url'), '/');
|
|
|
+
|
|
|
+ $this->isArchive = config('message.bark.bark_is_archive');
|
|
|
+ $this->group = config('message.bark.bark_group');
|
|
|
+ $this->level = config('message.bark.bark_level');
|
|
|
+ $this->icon = config('message.bark.bark_icon');
|
|
|
+ $this->jumpUrl = config('message.bark.bark_jump_url');
|
|
|
+
|
|
|
+ $this->client = new Client([
|
|
|
+ 'cookies' => false,
|
|
|
+ 'timeout' => self::TIMEOUT,
|
|
|
+ 'verify' => config('verify_ssl'),
|
|
|
+ 'debug' => config('debug'),
|
|
|
+ ]);
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 生成域名文本
|
|
|
+ *
|
|
|
+ * @param array $domains
|
|
|
+ *
|
|
|
+ * @return string
|
|
|
+ */
|
|
|
+ public function genDomainsText(array $domains)
|
|
|
+ {
|
|
|
+ $domainsText = '';
|
|
|
+
|
|
|
+ foreach ($domains as $domain) {
|
|
|
+ $domainsText .= sprintf('%s ', $domain);
|
|
|
+ }
|
|
|
+
|
|
|
+ $domainsText = trim($domainsText, ' ') . "\n";
|
|
|
+
|
|
|
+ return $domainsText;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 获取页脚
|
|
|
+ *
|
|
|
+ * @return string
|
|
|
+ */
|
|
|
+ public function getFooter()
|
|
|
+ {
|
|
|
+ $footer = '';
|
|
|
+
|
|
|
+ $footer .= "\n更多信息可以参考：https://my.freenom.com/domains.php?a=renewals（点击“复制内容”即可复制此网址）";
|
|
|
+ $footer .= "\n\n（如果你不想每次执行都收到推送，请将 .env 中 NOTICE_FREQ 的值设为 0，使程序只在有续期操作时才推送）";
|
|
|
+
|
|
|
+ return $footer;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 生成域名状态文本
|
|
|
+ *
|
|
|
+ * @param array $domainStatus
|
|
|
+ *
|
|
|
+ * @return string
|
|
|
+ */
|
|
|
+ public function genDomainStatusText(array $domainStatus)
|
|
|
+ {
|
|
|
+ if (empty($domainStatus)) {
|
|
|
+ return "无数据。\n";
|
|
|
+ }
|
|
|
+
|
|
|
+ $domainStatusText = '';
|
|
|
+
|
|
|
+ foreach ($domainStatus as $domain => $daysLeft) {
|
|
|
+ $domainStatusText .= sprintf('%s 还有 %d 天到期，', $domain, $daysLeft);
|
|
|
+ }
|
|
|
+
|
|
|
+ $domainStatusText = rtrim($domainStatusText, '，') . "。\n";
|
|
|
+
|
|
|
+ return $domainStatusText;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 生成域名续期结果文本
|
|
|
+ *
|
|
|
+ * @param string $username
|
|
|
+ * @param array $renewalSuccessArr
|
|
|
+ * @param array $renewalFailuresArr
|
|
|
+ * @param array $domainStatus
|
|
|
+ *
|
|
|
+ * @return string
|
|
|
+ */
|
|
|
+ public function genDomainRenewalResultsText(string $username, array $renewalSuccessArr, array $renewalFailuresArr, array $domainStatus)
|
|
|
+ {
|
|
|
+ $text = sprintf("账户 %s 这次续期的结果如下\n\n", $username);
|
|
|
+
|
|
|
+ if ($renewalSuccessArr) {
|
|
|
+ $text .= '续期成功：';
|
|
|
+ $text .= $this->genDomainsText($renewalSuccessArr);
|
|
|
+ }
|
|
|
+
|
|
|
+ if ($renewalFailuresArr) {
|
|
|
+ $text .= '续期出错：';
|
|
|
+ $text .= $this->genDomainsText($renewalFailuresArr);
|
|
|
+ }
|
|
|
+
|
|
|
+ $text .= "\n今次无需续期的域名及其剩余天数如下所示：\n\n";
|
|
|
+ $text .= $this->genDomainStatusText($domainStatus);
|
|
|
+
|
|
|
+ $text .= $this->getFooter();
|
|
|
+
|
|
|
+ return $text;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 生成域名状态完整文本
|
|
|
+ *
|
|
|
+ * @param string $username
|
|
|
+ * @param array $domainStatus
|
|
|
+ *
|
|
|
+ * @return string
|
|
|
+ */
|
|
|
+ public function genDomainStatusFullText(string $username, array $domainStatus)
|
|
|
+ {
|
|
|
+ $markDownText = sprintf("我刚刚帮小主看了一下，账户 %s 今天并没有需要续期的域名。所有域名情况如下：\n\n", $username);
|
|
|
+
|
|
|
+ $markDownText .= $this->genDomainStatusText($domainStatus);
|
|
|
+
|
|
|
+ $markDownText .= $this->getFooter();
|
|
|
+
|
|
|
+ return $markDownText;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 送信
|
|
|
+ *
|
|
|
+ * @param string $content
|
|
|
+ * @param string $subject
|
|
|
+ * @param int $type
|
|
|
+ * @param array $data
|
|
|
+ * @param string|null $recipient
|
|
|
+ * @param mixed ...$params
|
|
|
+ *
|
|
|
+ * @return bool|mixed
|
|
|
+ * @throws \Exception
|
|
|
+ */
|
|
|
+ public function send(string $content, string $subject = '', int $type = 1, array $data = [], ?string $recipient = null, ...$params)
|
|
|
+ {
|
|
|
+ $this->check($content, $data);
|
|
|
+
|
|
|
+ if ($type === 1) {
|
|
|
+ // Do nothing
|
|
|
+ } else if ($type === 2) {
|
|
|
+ $content = $this->genDomainRenewalResultsText($data['username'], $data['renewalSuccessArr'], $data['renewalFailuresArr'], $data['domainStatusArr']);
|
|
|
+ } else if ($type === 3) {
|
|
|
+ $content = $this->genDomainStatusFullText($data['username'], $data['domainStatusArr']);
|
|
|
+ } else {
|
|
|
+ throw new \Exception(lang('error_msg.100003'));
|
|
|
+ }
|
|
|
+
|
|
|
+ $query = [
|
|
|
+ 'level' => $this->level,
|
|
|
+ 'automaticallyCopy' => $this->automaticallyCopy, // 携带参数 automaticallyCopy=1， 收到推送时，推送内容会自动复制到粘贴板（如发现不能自动复制，可尝试重启一下手机）
|
|
|
+ 'copy' => $this->copy, // 携带 copy 参数，则上面的复制操作，将只复制 copy 参数的值
|
|
|
+ ];
|
|
|
+
|
|
|
+ if ($this->isArchive !== null) {
|
|
|
+ $query['isArchive'] = $this->isArchive;
|
|
|
+ }
|
|
|
+ if ($this->group !== null) {
|
|
|
+ $query['group'] = $this->group;
|
|
|
+ }
|
|
|
+ if ($this->icon !== null) {
|
|
|
+ $query['icon'] = $this->icon;
|
|
|
+ }
|
|
|
+ if ($this->jumpUrl !== null) {
|
|
|
+ $query['url'] = $this->jumpUrl;
|
|
|
+ }
|
|
|
+
|
|
|
+ $formParams = [
|
|
|
+ 'body' => $content, // 推送内容 换行请使用换行符 \n
|
|
|
+ ];
|
|
|
+
|
|
|
+ if ($subject !== '') {
|
|
|
+ $formParams['title'] = $subject; // 推送标题 比 body 字号粗一点
|
|
|
+ }
|
|
|
+
|
|
|
+ try {
|
|
|
+ $resp = $this->client->post(
|
|
|
+ sprintf('%s/%s/', $this->barkUrl, $this->barkKey),
|
|
|
+ [
|
|
|
+ 'query' => $query,
|
|
|
+ 'form_params' => $formParams,
|
|
|
+ ]
|
|
|
+ );
|
|
|
+
|
|
|
+ $resp = json_decode($resp->getBody()->getContents(), true);
|
|
|
+
|
|
|
+ if (isset($resp['code']) && $resp['code'] === 200) {
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+
|
|
|
+ throw new \Exception($resp['message'] ?? '未知原因');
|
|
|
+ } catch (\Exception $e) {
|
|
|
+ system_log('Bark 送信失败：<red>' . $e->getMessage() . '</red>');
|
|
|
+
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|
luolongfei