helpers.php 7.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267
  1. <?php
  2. /**
  3. * 助手函数
  4. *
  5. * @author mybsdc <[email protected]>
  6. * @date 2019/3/3
  7. * @time 16:34
  8. */
  9. use Luolongfei\App\Exceptions\LlfException;
  10. use Luolongfei\Libs\Argv;
  11. use Luolongfei\Libs\Config;
  12. use Luolongfei\Libs\Log;
  13. use Luolongfei\Libs\Env;
  14. use Luolongfei\Libs\Lang;
  15. use Luolongfei\Libs\PhpColor;
  16. use Luolongfei\App\Console\MigrateEnvFile;
  17. use Luolongfei\App\Console\Upgrade;
  18. if (!function_exists('config')) {
  19. /**
  20. * 获取配置
  21. *
  22. * @param string $key 键,支持点式访问
  23. * @param string $default 默认值
  24. *
  25. * @return array|mixed
  26. */
  27. function config($key = '', $default = null)
  28. {
  29. return Config::getInstance()->get($key, $default);
  30. }
  31. }
  32. if (!function_exists('lang')) {
  33. /**
  34. * 读取语言包
  35. *
  36. * @param string $key 键,支持点式访问
  37. *
  38. * @return array|mixed|null
  39. */
  40. function lang($key = '')
  41. {
  42. return Lang::getInstance()->get($key);
  43. }
  44. }
  45. if (!function_exists('system_log')) {
  46. /**
  47. * 写日志
  48. *
  49. * @param $content
  50. * @param array $response
  51. * @param string $fileName
  52. * @description 受支持的着色标签
  53. * 'reset', 'bold', 'dark', 'italic', 'underline', 'blink', 'reverse', 'concealed', 'default', 'black', 'red',
  54. * 'green', 'yellow', 'blue', 'magenta', 'cyan', 'light_gray', 'dark_gray', 'light_red', 'light_green',
  55. * 'light_yellow', 'light_blue', 'light_magenta', 'light_cyan', 'white', 'bg_default', 'bg_black', 'bg_red',
  56. * 'bg_green', 'bg_yellow', 'bg_blue', 'bg_magenta', 'bg_cyan', 'bg_light_gray', 'bg_dark_gray', 'bg_light_red',
  57. * 'bg_light_green','bg_light_yellow', 'bg_light_blue', 'bg_light_magenta', 'bg_light_cyan', 'bg_white'
  58. */
  59. function system_log($content, array $response = [], $fileName = '')
  60. {
  61. try {
  62. $path = sprintf('%s/logs/%s/', ROOT_PATH, date('Y-m'));
  63. $file = $path . ($fileName ?: date('d')) . '.log';
  64. if (!is_dir($path)) {
  65. mkdir($path, 0777, true);
  66. chmod($path, 0777);
  67. }
  68. $handle = fopen($file, 'a'); // 追加而非覆盖
  69. if (!filesize($file)) {
  70. chmod($file, 0666);
  71. }
  72. $msg = sprintf(
  73. "[%s] %s %s\n",
  74. date('Y-m-d H:i:s'),
  75. is_string($content) ? $content : json_encode($content),
  76. $response ? json_encode($response, JSON_UNESCAPED_UNICODE) : '');
  77. // 在 Github Actions 上运行,过滤敏感信息
  78. if (env('ON_GITHUB_ACTIONS')) {
  79. $msg = preg_replace_callback('/(?P<secret>[\w-.]{1,4}?)(?=@[\w-.]+)/i', function ($m) {
  80. return str_ireplace($m['secret'], str_repeat('*', strlen($m['secret'])), $m['secret']);
  81. }, $msg);
  82. }
  83. // 尝试为消息着色
  84. $c = PhpColor::getInstance()->getColorInstance();
  85. echo $c($msg)->colorize();
  86. // 干掉着色标签
  87. $msg = strip_tags($msg); // 不完整或者破损标签将导致更多的数据被删除
  88. fwrite($handle, $msg);
  89. fclose($handle);
  90. flush();
  91. } catch (\Exception $e) {
  92. // do nothing
  93. }
  94. }
  95. }
  96. if (!function_exists('is_locked')) {
  97. /**
  98. * 检查任务是否已被锁定
  99. *
  100. * @param string $taskName
  101. * @param bool $always 是否被永久锁定
  102. *
  103. * @return bool
  104. * @throws Exception
  105. */
  106. function is_locked($taskName = '', $always = false)
  107. {
  108. try {
  109. $lock = sprintf(
  110. '%s/num_limit/%s/%s.lock',
  111. APP_PATH,
  112. $always ? 'always' : date('Y-m-d'),
  113. $taskName
  114. );
  115. return file_exists($lock);
  116. } catch (\Exception $e) {
  117. system_log(sprintf('检查任务%s是否锁定时出错,错误原因:%s', $taskName, $e->getMessage()));
  118. }
  119. return false;
  120. }
  121. }
  122. if (!function_exists('lock_task')) {
  123. /**
  124. * 锁定任务
  125. *
  126. * 防止重复执行
  127. *
  128. * @param string $taskName
  129. * @param bool $always 是否永久锁定
  130. *
  131. * @return bool
  132. */
  133. function lock_task($taskName = '', $always = false)
  134. {
  135. try {
  136. $lock = sprintf(
  137. '%s/num_limit/%s/%s.lock',
  138. APP_PATH,
  139. $always ? 'always' : date('Y-m-d'),
  140. $taskName
  141. );
  142. $path = dirname($lock);
  143. if (!is_dir($path)) {
  144. mkdir($path, 0777, true);
  145. chmod($path, 0777);
  146. }
  147. if (file_exists($lock)) {
  148. return true;
  149. }
  150. $handle = fopen($lock, 'a'); // 追加而非覆盖
  151. if (!filesize($lock)) {
  152. chmod($lock, 0666);
  153. }
  154. fwrite($handle, sprintf(
  155. "Locked at %s.\n",
  156. date('Y-m-d H:i:s')
  157. )
  158. );
  159. fclose($handle);
  160. Log::info(sprintf('%s已被锁定,此任务%s已不会再执行,请知悉', $taskName, $always ? '' : '今天内'));
  161. } catch (\Exception $e) {
  162. system_log(sprintf('创建锁定任务文件%s时出错,错误原因:%s', $lock, $e->getMessage()));
  163. return false;
  164. }
  165. return true;
  166. }
  167. }
  168. if (!function_exists('env')) {
  169. /**
  170. * 获取环境变量值
  171. *
  172. * @param string $key
  173. * @param string $default 默认值
  174. *
  175. * @return array | bool | false | null | string
  176. */
  177. function env($key = '', $default = null)
  178. {
  179. return Env::getInstance()->get($key, $default);
  180. }
  181. }
  182. if (!function_exists('get_argv')) {
  183. /**
  184. * 获取命令行传参
  185. *
  186. * @param string $name
  187. * @param string $default 默认值
  188. *
  189. * @return mixed|string
  190. */
  191. function get_argv(string $name, string $default = '')
  192. {
  193. return Argv::getInstance()->get($name, $default);
  194. }
  195. }
  196. if (!function_exists('system_check')) {
  197. /**
  198. * 检查环境是否满足要求
  199. *
  200. * @throws LlfException
  201. */
  202. function system_check()
  203. {
  204. if (version_compare(PHP_VERSION, '7.0.0') < 0) {
  205. throw new LlfException(34520006);
  206. }
  207. // 如果是在云函数部署,则不需要检查这几项
  208. if (IS_SCF) {
  209. system_log('检测到运行环境为云函数,所有环境变量将直接从环境中读取,环境中找不到的变量,则直接从 .env.example 文件中读取');
  210. system_log('如果是在腾讯云函数,可以参考此处修改或新增环境变量,无需重建:https://github.com/luolongfei/freenom/blob/main/resources/screenshot/scf03.png');
  211. system_log('如果是在阿里云函数,可以直接在【函数详情】->【函数配置】->【环境信息】处编辑环境变量');
  212. } else {
  213. if (!function_exists('putenv')) {
  214. throw new LlfException(34520005);
  215. }
  216. $envFile = ROOT_PATH . '/.env';
  217. if (!file_exists($envFile)) {
  218. throw new LlfException(copy(ROOT_PATH . '/.env.example', $envFile) ? 34520007 : 34520008);
  219. }
  220. // 检查当前 .env 文件版本是否过低,过低自动升级
  221. MigrateEnvFile::getInstance()->handle();
  222. }
  223. // 是否有新版可用
  224. if (config('new_version_detection')) {
  225. Upgrade::getInstance()->handle();
  226. } else {
  227. system_log('由于你没有开启升级提醒功能,故无法在有新版本可用时第一时间收到通知。将 .env 文件中 NEW_VERSION_DETECTION 的值改为 1 即可重新开启相关功能。');
  228. }
  229. if (!extension_loaded('curl')) {
  230. throw new LlfException(34520010);
  231. }
  232. }
  233. }