helpers.php 8.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326
  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. * system_log('<light_magenta>颜色 light_magenta</light_magenta>');
  60. */
  61. function system_log($content, array $response = [], $fileName = '')
  62. {
  63. try {
  64. # 云函数只有 /tmp 目录可写
  65. $path = IS_SCF ? '/tmp/' : sprintf('%s/logs/%s/', ROOT_PATH, date('Y-m'));
  66. $file = $path . ($fileName ?: date('d')) . '.log';
  67. if (!is_dir($path)) {
  68. mkdir($path, 0777, true);
  69. chmod($path, 0777);
  70. }
  71. $handle = fopen($file, 'a'); // 追加而非覆盖
  72. if (!filesize($file)) {
  73. chmod($file, 0666);
  74. }
  75. $msg = sprintf(
  76. "[%s] %s %s\n",
  77. date('Y-m-d H:i:s'),
  78. is_string($content) ? $content : json_encode($content),
  79. $response ? json_encode($response, JSON_UNESCAPED_UNICODE) : '');
  80. // 在 Github Actions 上运行,过滤敏感信息
  81. if (env('ON_GITHUB_ACTIONS')) {
  82. $msg = preg_replace_callback('/(?P<secret>[\w-.]{1,4}?)(?=@[\w-.]+)/i', function ($m) {
  83. return str_ireplace($m['secret'], str_repeat('*', strlen($m['secret'])), $m['secret']);
  84. }, $msg);
  85. }
  86. // 尝试为消息着色
  87. $c = PhpColor::getInstance()->getColorInstance();
  88. echo $c($msg)->colorize();
  89. // 干掉着色标签
  90. $msg = strip_tags($msg); // 不完整或者破损标签将导致更多的数据被删除
  91. fwrite($handle, $msg);
  92. fclose($handle);
  93. flush();
  94. } catch (\Exception $e) {
  95. // do nothing
  96. }
  97. }
  98. }
  99. if (!function_exists('is_locked')) {
  100. /**
  101. * 检查任务是否已被锁定
  102. *
  103. * @param string $taskName
  104. * @param bool $always 是否被永久锁定
  105. *
  106. * @return bool
  107. * @throws Exception
  108. */
  109. function is_locked($taskName = '', $always = false)
  110. {
  111. try {
  112. $lock = sprintf(
  113. '%s/num_limit/%s/%s.lock',
  114. APP_PATH,
  115. $always ? 'always' : date('Y-m-d'),
  116. $taskName
  117. );
  118. return file_exists($lock);
  119. } catch (\Exception $e) {
  120. system_log(sprintf('检查任务%s是否锁定时出错,错误原因:%s', $taskName, $e->getMessage()));
  121. }
  122. return false;
  123. }
  124. }
  125. if (!function_exists('lock_task')) {
  126. /**
  127. * 锁定任务
  128. *
  129. * 防止重复执行
  130. *
  131. * @param string $taskName
  132. * @param bool $always 是否永久锁定
  133. *
  134. * @return bool
  135. */
  136. function lock_task($taskName = '', $always = false)
  137. {
  138. try {
  139. $lock = sprintf(
  140. '%s/num_limit/%s/%s.lock',
  141. APP_PATH,
  142. $always ? 'always' : date('Y-m-d'),
  143. $taskName
  144. );
  145. $path = dirname($lock);
  146. if (!is_dir($path)) {
  147. mkdir($path, 0777, true);
  148. chmod($path, 0777);
  149. }
  150. if (file_exists($lock)) {
  151. return true;
  152. }
  153. $handle = fopen($lock, 'a'); // 追加而非覆盖
  154. if (!filesize($lock)) {
  155. chmod($lock, 0666);
  156. }
  157. fwrite($handle, sprintf(
  158. "Locked at %s.\n",
  159. date('Y-m-d H:i:s')
  160. )
  161. );
  162. fclose($handle);
  163. Log::info(sprintf('%s已被锁定,此任务%s已不会再执行,请知悉', $taskName, $always ? '' : '今天内'));
  164. } catch (\Exception $e) {
  165. system_log(sprintf('创建锁定任务文件%s时出错,错误原因:%s', $lock, $e->getMessage()));
  166. return false;
  167. }
  168. return true;
  169. }
  170. }
  171. if (!function_exists('env')) {
  172. /**
  173. * 获取环境变量值
  174. *
  175. * @param string $key
  176. * @param string $default 默认值
  177. *
  178. * @return array | bool | false | null | string
  179. */
  180. function env($key = '', $default = null)
  181. {
  182. return Env::getInstance()->get($key, $default);
  183. }
  184. }
  185. if (!function_exists('get_argv')) {
  186. /**
  187. * 获取命令行传参
  188. *
  189. * @param string $name
  190. * @param string $default 默认值
  191. *
  192. * @return mixed|string
  193. */
  194. function get_argv(string $name, string $default = '')
  195. {
  196. return Argv::getInstance()->get($name, $default);
  197. }
  198. }
  199. if (!function_exists('system_check')) {
  200. /**
  201. * 检查环境是否满足要求
  202. *
  203. * @throws LlfException
  204. */
  205. function system_check()
  206. {
  207. // 由于各种云函数目前支持的最大的 PHP 版本为 7.2,故此处暂时不强制要求升级 PHP 7.3 以获得更好的兼容性
  208. if (version_compare(PHP_VERSION, '7.2.0') < 0) {
  209. throw new LlfException(34520006, ['7.3', PHP_VERSION]);
  210. }
  211. // 如果是在 云函数 或 Heroku 部署,则不需要检查这几项
  212. if (IS_SCF || (int)env('IS_HEROKU') === 1) {
  213. system_log(lang('100009'));
  214. system_log(lang('100010'));
  215. system_log(lang('100011'));
  216. } else {
  217. if (!function_exists('putenv')) {
  218. throw new LlfException(34520005);
  219. }
  220. $envFile = ROOT_PATH . '/.env';
  221. if (!file_exists($envFile)) {
  222. throw new LlfException(copy(ROOT_PATH . '/.env.example', $envFile) ? 34520007 : 34520008);
  223. }
  224. // 检查当前 .env 文件版本是否过低,过低自动升级
  225. MigrateEnvFile::getInstance()->handle();
  226. }
  227. // 是否有新版可用
  228. if (config('new_version_detection')) {
  229. Upgrade::getInstance()->handle();
  230. } else {
  231. system_log(lang('100012'));
  232. }
  233. if (!extension_loaded('curl')) {
  234. throw new LlfException(34520010);
  235. }
  236. }
  237. }
  238. if (!function_exists('get_local_num')) {
  239. /**
  240. * 获取当地数字
  241. *
  242. * @param string|int $num
  243. *
  244. * @return string
  245. */
  246. function get_local_num($num)
  247. {
  248. $num = (string)$num;
  249. if (\config('language') === 'zh') {
  250. return $num;
  251. }
  252. // 英文数字规则
  253. $lastDigit = substr($num, -1);
  254. switch ($lastDigit) {
  255. case '1':
  256. return $num . 'st';
  257. case '2':
  258. return $num . 'nd';
  259. case '3':
  260. return $num . 'rd';
  261. default:
  262. return $num . 'th';
  263. }
  264. }
  265. }
  266. if (!function_exists('is_chinese')) {
  267. /**
  268. * 判断当前语言环境
  269. *
  270. * @return bool
  271. */
  272. function is_chinese()
  273. {
  274. return config('language', 'zh') === 'zh';
  275. }
  276. }
  277. if (!function_exists('get_ip_info')) {
  278. /**
  279. * 获取 ip 信息
  280. *
  281. * @return string
  282. */
  283. function get_ip_info()
  284. {
  285. return \Luolongfei\Libs\IP::getInstance()->get();
  286. }
  287. }