ConfigService.php 4.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164
  1. <?php
  2. namespace App\Services;
  3. use App\Services\BaseService;
  4. use App\Models\Config;
  5. use Illuminate\Support\Facades\DB;
  6. use Illuminate\Support\Collection;
  7. use Illuminate\Support\Facades\Cache;
  8. use Illuminate\Support\Facades\Log;
  9. /**
  10. * 配置
  11. */
  12. class ConfigService extends BaseService
  13. {
  14. /**
  15. * @description: 模型
  16. * @return {string}
  17. */
  18. public static function model(): string
  19. {
  20. return Config::class;
  21. }
  22. /**
  23. * @description: 枚举
  24. * @return {*}
  25. */
  26. public static function enum(): string
  27. {
  28. return '';
  29. }
  30. /**
  31. * @description: 获取查询条件
  32. * @param {array} $search 查询内容
  33. * @return {array}
  34. */
  35. public static function getWhere(array $search = []): array
  36. {
  37. $where = [];
  38. if (isset($search['field']) && !empty($search['field'])) {
  39. $where[] = ['field', '=', $search['field']];
  40. }
  41. if (isset($search['group_id']) && !empty($search['group_id'])) {
  42. if (!is_array($search['group_id'])) {
  43. $where[] = ['group_id', '=', $search['group_id']];
  44. }
  45. }
  46. if (isset($search['id']) && !empty($search['id'])) {
  47. $where[] = ['id', '=', $search['id']];
  48. }
  49. return $where;
  50. }
  51. public static function getWhereIn(array $search = []): array
  52. {
  53. $where = [];
  54. if (isset($search['in_group_id']) && is_array($search['in_group_id'])) {
  55. $where['group_id'] = $search['in_group_id'];
  56. }
  57. return $where;
  58. }
  59. /**
  60. * @description: 查询单条数据
  61. * @param array $search
  62. * @return \App\Models\Coin|null
  63. */
  64. public static function findOne(array $search): ?Config
  65. {
  66. return self::model()::where(self::getWhere($search))->first();
  67. }
  68. /**
  69. * @description: 查询所有数据
  70. * @param array $search
  71. * @return \Illuminate\Database\Eloquent\Collection
  72. */
  73. public static function findAll(array $search = [])
  74. {
  75. return self::model()::where(self::getWhere($search))->get();
  76. }
  77. /**
  78. * @description: 分页查询
  79. * @param array $search
  80. * @return \Illuminate\Contracts\Pagination\LengthAwarePaginator
  81. */
  82. public static function paginate(array $search = [])
  83. {
  84. $limit = isset($search['limit']) ? $search['limit'] : 15;
  85. $query = self::model()::where(self::getWhere($search));
  86. $where = self::getWhereIn($search);
  87. foreach ($where as $key => $value) {
  88. $query = $query->whereIn($key, $search['in_group_id']);
  89. }
  90. $paginator = $query->paginate($limit);
  91. return ['total' => $paginator->total(), 'data' => $paginator->items()];
  92. }
  93. /**
  94. * @description:
  95. * @param {*} $params
  96. * @return {*}
  97. */
  98. public static function submit($params = [])
  99. {
  100. $result = false;
  101. $msg['code'] = self::NOT;
  102. $msg['msg'] = '';
  103. // 2. 判断是否是更新
  104. if (!empty($params['id'])) {
  105. // 更新
  106. $info = self::findOne(['id' => $params['id']]);
  107. if (!$info) {
  108. $msg['msg'] = '配置不存在!';
  109. } else {
  110. unset($params['field']);
  111. $result = $info->update($params);
  112. $id = $params['id'];
  113. }
  114. } else {
  115. // 创建
  116. $result = $info = self::model()::create($params);
  117. $id = $result->id;
  118. }
  119. if ($result) {
  120. $msg['code'] = self::YES;
  121. $msg['msg'] = '设置成功';
  122. } else {
  123. $msg['msg'] = empty($msg['msg']) ? '操作失败' : $msg['msg'];
  124. }
  125. return $msg;
  126. }
  127. public static function syncExchangeRate()
  128. {
  129. $url = "https://cdn.jsdelivr.net/npm/@fawazahmed0/currency-api@latest/v1/currencies/usd.json";
  130. $result = file_get_contents($url, false, stream_context_create([
  131. 'http' => [
  132. 'method' => 'GET',
  133. 'header' => "User-Agent: Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/58.0.3029.110 Safari/537.3\r\n"
  134. ]
  135. ]));
  136. $result = json_decode($result, true);
  137. $rate = number_format($result['usd']['cnh'], 2);
  138. $info = self::findOne(['field' => 'exchange_rate_rmb']);
  139. $info->val = $rate;
  140. $info->save();
  141. return $result;
  142. }
  143. }