BaseService.php 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493
  1. <?php
  2. namespace App\Services;
  3. use SimpleSoftwareIO\QrCode\Facades\QrCode;
  4. use Endroid\QrCode\Builder\Builder;
  5. use Endroid\QrCode\Writer\PngWriter;
  6. use Telegram\Bot\Api;
  7. use App\Models\Config;
  8. use Telegram\Bot\FileUpload\InputFile;
  9. use Illuminate\Support\Facades\Log;
  10. use App\Jobs\SendTelegramMessageJob;
  11. use App\Jobs\SendTelegramGroupMessageJob;
  12. class BaseService
  13. {
  14. const YES = 1;
  15. const NOT = 0;
  16. /**
  17. * @description: 生成充值二维码
  18. * @param {*} $address 充值地址
  19. * @return {*}
  20. */
  21. public static function createRechargeQrCode($address = '')
  22. {
  23. $content = $address;
  24. $qrSize = 300;
  25. $font = 4;
  26. $textHeight = 20;
  27. $padding = 10;
  28. // 生成二维码图像对象
  29. $result = Builder::create()
  30. ->writer(new PngWriter())
  31. ->data($content)
  32. ->size($qrSize)
  33. ->margin(0)
  34. ->build();
  35. $qrImage = imagecreatefromstring($result->getString());
  36. // 创建画布(加上下方文字区和边距)
  37. $canvasWidth = $qrSize + $padding * 2;
  38. $canvasHeight = $qrSize + $textHeight + $padding * 2;
  39. $image = imagecreatetruecolor($canvasWidth, $canvasHeight);
  40. // 背景白色
  41. $white = imagecolorallocate($image, 255, 255, 255);
  42. imagefill($image, 0, 0, $white);
  43. // 黑色字体
  44. $black = imagecolorallocate($image, 0, 0, 0);
  45. // 合并二维码图像
  46. imagecopy($image, $qrImage, $padding, $padding, 0, 0, $qrSize, $qrSize);
  47. // 写文字
  48. $textWidth = imagefontwidth($font) * strlen($content);
  49. $x = ($canvasWidth - $textWidth) / 2;
  50. $y = $qrSize + $padding + 5;
  51. imagestring($image, $font, $x, $y, $content, $black);
  52. // 生成文件名
  53. $filename = $address. '.png';
  54. $relativePath = 'recharge/' . $filename;
  55. $storagePath = storage_path('app/public/' . $relativePath);
  56. // 确保目录存在
  57. @mkdir(dirname($storagePath), 0777, true);
  58. // 保存图片到文件
  59. imagepng($image, $storagePath);
  60. // 清理
  61. imagedestroy($qrImage);
  62. imagedestroy($image);
  63. // 返回 public 存储路径(可用于 URL)
  64. return 'storage/'.$relativePath; // 或返回 Storage::url($relativePath);
  65. }
  66. /**
  67. * 判断指定地址的二维码是否已生成(已存在文件)
  68. *
  69. * @param string $address 充值地址
  70. * @return
  71. */
  72. public static function rechargeQrCodeExists(string $address)
  73. {
  74. $filename = $address . '.png';
  75. $relativePath = 'recharge/' . $filename;
  76. $storagePath = storage_path('app/public/' . $relativePath);
  77. $path = '';
  78. if(file_exists($storagePath)){
  79. $path = 'storage/'.$relativePath;
  80. }
  81. return $path;
  82. }
  83. /**
  84. * @description: 转成树形数据
  85. * @param {*} $list 初始数据
  86. * @param {*} $pid 父id
  87. * @param {*} $level 层级
  88. * @param {*} $pid_name pid字段名称 默认pid
  89. * @param {*} $id_name 主键id 名称
  90. * @return {*}
  91. */
  92. public static function toTree($list,$pid=0,$level=0,$pid_name='pid',$id_name='id')
  93. {
  94. $arr=[];
  95. $level++;
  96. foreach($list as $k => $v){
  97. if($pid==$v[$pid_name]){
  98. $v['level']=$level;
  99. $v['children']=self::toTree($list,$v[$id_name],$level,$pid_name,$id_name);
  100. $arr[]=$v;
  101. }
  102. }
  103. return $arr;
  104. }
  105. /**
  106. * @description: 实例化TG
  107. * @return {*}
  108. */
  109. public static function telegram()
  110. {
  111. return app(Api::class);
  112. }
  113. // /**
  114. // * @description: 群组通知(自动分段发送,支持中文与多字节字符)
  115. // * @param string $text 通知内容
  116. // * @param array $keyboard 操作按钮
  117. // * @param string $image 图片路径(可选)
  118. // * @param bool $isTop 是否置顶第一条消息
  119. // */
  120. // public static function bettingGroupNotice($text, $keyboard = [], $image = '', $isTop = false)
  121. // {
  122. // $bettingGroup = Config::where('field', 'betting_group')->first()->val;
  123. // $telegram = self::telegram();
  124. //
  125. // $maxLen = 1024; // Telegram 限制:最多 1024 个字符
  126. // $textParts = [];
  127. // $textLength = mb_strlen($text, 'UTF-8');
  128. // for ($i = 0; $i < $textLength; $i += $maxLen) {
  129. // $textParts[] = mb_substr($text, $i, $maxLen, 'UTF-8');
  130. // }
  131. //
  132. // $firstMessageId = null;
  133. //
  134. // foreach ($textParts as $index => $partText) {
  135. // $botMsg = [
  136. // 'chat_id' => "@{$bettingGroup}",
  137. // 'text' => $partText,
  138. // ];
  139. //
  140. // if (count($keyboard) > 0 && $index === 0) {
  141. // $botMsg['reply_markup'] = json_encode(['inline_keyboard' => $keyboard]);
  142. // }
  143. //
  144. // if (!empty($image) && $index === 0) {
  145. // // 第一条带图片
  146. // $botMsg['photo'] = InputFile::create($image);
  147. // $botMsg['caption'] = $partText;
  148. // $botMsg['protect_content'] = true;
  149. // $response = $telegram->sendPhoto($botMsg);
  150. // } else {
  151. // $response = $telegram->sendMessage($botMsg);
  152. // }
  153. //
  154. // if ($isTop && $index === 0 && $response && $response->get('message_id')) {
  155. // $firstMessageId = $response->get('message_id');
  156. // }
  157. //
  158. // // 防止限流(可选)
  159. // usleep(300000);
  160. // }
  161. //
  162. // if ($isTop && $firstMessageId) {
  163. // $telegram->pinChatMessage([
  164. // 'chat_id' => "@{$bettingGroup}",
  165. // 'message_id' => $firstMessageId
  166. // ]);
  167. // }
  168. // }
  169. /**
  170. * @description: 群组通知
  171. * @param {string} $text 通知内容
  172. * @param {array} $keyboard 操作按钮
  173. * @param {*string} $image 图片
  174. * @return {*}
  175. */
  176. public static function bettingGroupNotice($text ,$keyboard = [], $image = '' ,$isTop = false)
  177. {
  178. $bettingGroup = Config::where('field', 'betting_group')->first()->val;
  179. $botMsg = [
  180. 'chat_id' => "@{$bettingGroup}",
  181. 'text' => $text
  182. ];
  183. if(count($keyboard)>0){
  184. $botMsg['reply_markup'] = json_encode(['inline_keyboard' => $keyboard]);
  185. }
  186. if(!empty($image)){
  187. $botMsg['photo'] = InputFile::create($image);
  188. $botMsg['caption'] = $text;
  189. $botMsg['protect_content'] = true; // 防止转发
  190. $response = self::telegram()->sendPhoto($botMsg);
  191. }else{
  192. $response = self::telegram()->sendMessage($botMsg);
  193. }
  194. if($isTop == true){
  195. // 获取消息ID
  196. $messageId = $response->get('message_id');
  197. // 置顶消息
  198. self::telegram()->pinChatMessage([
  199. 'chat_id' => "@{$bettingGroup}",
  200. 'message_id' => $messageId
  201. ]);
  202. }
  203. }
  204. /**
  205. * @description: 异步群组通知
  206. * @param {string} $text 通知内容
  207. * @param {array} $keyboard 操作按钮
  208. * @param {*string} $image 图片
  209. * @return {*}
  210. */
  211. public static function asyncBettingGroupNotice($text ,$keyboard = [], $image = '' ,$isTop = false)
  212. {
  213. SendTelegramGroupMessageJob::dispatch($text ,$keyboard ,$image ,$isTop);
  214. }
  215. /**
  216. * @description: 发送消息
  217. * @param {string} $chatId 聊天ID
  218. * @param {string} $text 消息内容
  219. * @param {array} $keyboard 操作按钮
  220. * @param {*string} $image 图片
  221. * @return {*}
  222. */
  223. public static function sendMessage($chatId ,$text ,$keyboard = [] ,$image = '')
  224. {
  225. $botMsg = [
  226. 'chat_id' => $chatId,
  227. ];
  228. if(count($keyboard)>0){
  229. $botMsg['reply_markup'] = json_encode(['inline_keyboard' => $keyboard]);
  230. }
  231. if($image != ''){
  232. $botMsg['photo'] = InputFile::create($image);
  233. $botMsg['caption'] = $text;
  234. $botMsg['protect_content'] = true; // 防止转发
  235. self::telegram()->sendPhoto($botMsg);
  236. }else{
  237. $botMsg['text'] = $text;
  238. self::telegram()->sendMessage($botMsg);
  239. }
  240. }
  241. /**
  242. * @description: 异步发送消息
  243. * @param {string} $chatId 聊天ID
  244. * @param {string} $text 消息内容
  245. * @param {array} $keyboard 操作按钮
  246. * @param {*string} $image 图片
  247. * @return {*}
  248. */
  249. public static function asyncSendMessage($chatId ,$text ,$keyboard = [] ,$image = '')
  250. {
  251. SendTelegramMessageJob::dispatch($chatId ,$text ,$keyboard ,$image);
  252. }
  253. /**
  254. * @description: 弹窗提示
  255. * @param {*} $memberId
  256. * @param {*} $address
  257. * @return {*}
  258. */
  259. public static function alertNotice($callbackId ,$text)
  260. {
  261. self::telegram()->answerCallbackQuery([
  262. 'callback_query_id' => $callbackId,
  263. 'text' => $text,
  264. 'show_alert' => true // 显示为弹窗
  265. ]);
  266. }
  267. public static function log($message, $context = [])
  268. {
  269. Log::error($message, $context);
  270. }
  271. /**
  272. * @description: 获取操作按钮
  273. * @return {*}
  274. */
  275. public static function getOperateButton()
  276. {
  277. $replyInfo = KeyboardService::findOne(['button' => '投注菜单']);
  278. if($replyInfo && $replyInfo->buttons){
  279. $buttons = json_decode($replyInfo->buttons, true);
  280. foreach ($buttons as $row) {
  281. $inlineButton[] = [];
  282. foreach ($row as $button) {
  283. $btn = ['text' => $button['text']];
  284. if(strpos($button['url'], 'http') === 0){
  285. $btn['url'] = $button['url'];
  286. }else{
  287. $btn['callback_data'] = $button['url'];
  288. }
  289. $inlineButton[count($inlineButton) - 1][] = $btn;
  290. // if (isset($button['text'])) {
  291. // $btn = ['text' => $button['text']];
  292. // if (isset($button['callback_data'])) {
  293. // $btn['callback_data'] = $button['callback_data'];
  294. // }
  295. // if (isset($button['url'])) {
  296. // $btn['url'] = $button['url'];
  297. // }
  298. // $inlineButton[count($inlineButton) - 1][] = $btn;
  299. // }
  300. }
  301. }
  302. $inlineButton = array_values($inlineButton);
  303. return $inlineButton;
  304. }
  305. // $username = config('services.telegram.username');
  306. // $serviceAccount = Config::where('field', 'service_account')->first()->val??'';
  307. // $officialChannel = Config::where('field', 'official_channel')->first()->val??'';
  308. $inlineButton = [];
  309. // $inlineButton[] = [
  310. // ['text' => "查看余额", 'callback_data' => 'balanceAlert'],
  311. // ['text' => "✅唯一财务", 'url' => "https://t.me/{$serviceAccount}"]
  312. // ];
  313. // $inlineButton[] = [
  314. // ['text' => "近期注单", 'callback_data' => 'betsAlert'],
  315. // ['text' => "今日流水", 'callback_data' => 'todayFlowAlert']
  316. // ];
  317. // $inlineButton[] = [
  318. // ['text' => "私聊下注", 'url' => "https://t.me/{$username}"]
  319. // ];
  320. // $inlineButton[] = [
  321. // ['text' => "官方频道", 'url' => "https://t.me/{$officialChannel}"]
  322. // ];
  323. return $inlineButton;
  324. }
  325. // 获取字符串最后几个字符
  326. public static function getLastChar($str,$num = 1)
  327. {
  328. $length = mb_strlen($str, 'UTF-8');
  329. $lastChar = mb_substr($str, $length - 1, $num, 'UTF-8');
  330. return $lastChar;
  331. }
  332. public static function generateRandomString($length = 8) {
  333. $characters = '0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ';
  334. $randomString = '';
  335. for ($i = 0; $i < $length; $i++) {
  336. $randomString .= $characters[rand(0, strlen($characters) - 1)];
  337. }
  338. return $randomString;
  339. }
  340. public static function generateRandomNumber($length = 8) {
  341. $characters = '0123456789';
  342. $randomString = '';
  343. for ($i = 0; $i < $length; $i++) {
  344. $randomString .= rand(1, 9);
  345. }
  346. return $randomString;
  347. }
  348. public static function hideMiddleDigits($number, $hideCount = 4) {
  349. $length = strlen($number);
  350. if ($length <= $hideCount) {
  351. // 数字太短,全部隐藏
  352. return str_repeat("*", $length);
  353. }
  354. // 计算中间开始隐藏的位置
  355. $startLen = floor(($length - $hideCount) / 2);
  356. $endLen = $length - $hideCount - $startLen;
  357. $start = substr($number, 0, $startLen);
  358. $end = substr($number, -$endLen);
  359. return $start . str_repeat("*", $hideCount) . $end;
  360. }
  361. // 生成订单号
  362. public static function createOrderNo($prefix = 'pc28_',$memberId = null)
  363. {
  364. // 处理会员ID,获取后四位
  365. if ($memberId) {
  366. $memberSuffix = str_pad(substr($memberId, -4), 4, '0', STR_PAD_LEFT);
  367. } else {
  368. $memberSuffix = '0000'; // 默认值
  369. }
  370. // 时间部分
  371. $timePart = date('YmdHis');
  372. // 随机部分增加唯一性
  373. $randomPart = mt_rand(1000, 9999);
  374. return $prefix . $timePart . $randomPart . $memberSuffix;
  375. }
  376. /**
  377. * @description: 生成支付二维码
  378. * @param {*} $address 支付地址
  379. * @return {*}
  380. */
  381. public static function createPaymentQrCode($address = '')
  382. {
  383. $content = $address;
  384. $qrSize = 300;
  385. $font = 4;
  386. $textHeight = 20;
  387. $padding = 10;
  388. // 生成二维码图像对象
  389. $result = Builder::create()
  390. ->writer(new PngWriter())
  391. ->data($content)
  392. ->size($qrSize)
  393. ->margin(0)
  394. ->build();
  395. $qrImage = imagecreatefromstring($result->getString());
  396. // 创建画布(加上下方文字区和边距)
  397. $canvasWidth = $qrSize + $padding * 2;
  398. $canvasHeight = $qrSize + $textHeight + $padding * 2;
  399. $image = imagecreatetruecolor($canvasWidth, $canvasHeight);
  400. // 背景白色
  401. $white = imagecolorallocate($image, 255, 255, 255);
  402. imagefill($image, 0, 0, $white);
  403. // 黑色字体
  404. $black = imagecolorallocate($image, 0, 0, 0);
  405. // 合并二维码图像
  406. imagecopy($image, $qrImage, $padding, $padding, 0, 0, $qrSize, $qrSize);
  407. // 写文字
  408. $textWidth = imagefontwidth($font) * strlen($content);
  409. $x = ($canvasWidth - $textWidth) / 2;
  410. $y = $qrSize + $padding + 5;
  411. imagestring($image, $font, $x, $y, $content, $black);
  412. $address_name = self::generateRandomString(20).time();
  413. // 生成文件名
  414. $filename = $address_name. '.png';
  415. $relativePath = 'payment/' . $filename;
  416. $storagePath = storage_path('app/public/' . $relativePath);
  417. // 确保目录存在
  418. @mkdir(dirname($storagePath), 0777, true);
  419. // 保存图片到文件
  420. imagepng($image, $storagePath);
  421. // 清理
  422. imagedestroy($qrImage);
  423. imagedestroy($image);
  424. // 返回 public 存储路径(可用于 URL)
  425. return 'storage/'.$relativePath; // 或返回 Storage::url($relativePath);
  426. }
  427. }