MemberBankService.php 5.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162
  1. <?php
  2. // +----------------------------------------------------------------------
  3. // | LARAVEL8.0 框架 [ LARAVEL ][ RXThinkCMF ]
  4. // +----------------------------------------------------------------------
  5. // | 版权所有 2017~2021 LARAVEL研发中心
  6. // +----------------------------------------------------------------------
  7. // | 官方网站: http://www.laravel.cn
  8. // +----------------------------------------------------------------------
  9. // | Author: laravel开发员 <laravel.qq.com>
  10. // +----------------------------------------------------------------------
  11. namespace App\Services\Api;
  12. use App\Models\MemberBankModel;
  13. use App\Services\BaseService;
  14. use App\Services\RedisService;
  15. /**
  16. * 用户银行卡管理-服务类
  17. * @author laravel开发员
  18. * @since 2020/11/11
  19. * Class MemberBankService
  20. * @package App\Services\Common
  21. */
  22. class MemberBankService extends BaseService
  23. {
  24. // 静态对象
  25. protected static $instance = null;
  26. /**
  27. * 构造函数
  28. * @author laravel开发员
  29. * @since 2020/11/11
  30. * MemberBankService constructor.
  31. */
  32. public function __construct()
  33. {
  34. $this->model = new MemberBankModel();
  35. }
  36. /**
  37. * 静态入口
  38. * @return static|null
  39. */
  40. public static function make()
  41. {
  42. if (!self::$instance) {
  43. self::$instance = (new static());
  44. }
  45. return self::$instance;
  46. }
  47. /**
  48. * 列表数据
  49. * @param $params
  50. * @param int $pageSize
  51. * @return array
  52. */
  53. public function getDataList($params, $pageSize = 15)
  54. {
  55. $where = ['a.mark' => 1,'a.status'=>1];
  56. $status = isset($params['status']) ? $params['status'] : 0;
  57. if ($status > 0) {
  58. $where['a.status'] = $status;
  59. }
  60. $userId = isset($params['user_id']) ? $params['user_id'] : 0;
  61. if ($userId > 0) {
  62. $where['a.user_id'] = $userId;
  63. }
  64. $list = $this->model->from('member_banks as a')
  65. ->where($where)
  66. ->select(['a.*'])
  67. ->orderBy('a.create_time', 'desc')
  68. ->orderBy('a.id', 'desc')
  69. ->paginate($pageSize > 0 ? $pageSize : 9999999);
  70. $list = $list ? $list->toArray() : [];
  71. if ($list) {
  72. foreach ($list['data'] as &$item) {
  73. $item['create_time'] = $item['create_time'] ? datetime($item['create_time'], 'Y-m-d H.i.s') : '';
  74. $item['bank_card_text'] = $item['bank_card'] ? format_bank_card($item['bank_card']) : '';
  75. $item['name_text'] = $item['bank_name'] ? mb_substr($item['bank_name'],0,1,'utf-8') : '';
  76. $item['icon'] = $item['bank_code'] ? get_image_url('/images/icons/banks/icon-'.$item['bank_code'].'.png') : '';
  77. }
  78. }
  79. return [
  80. 'pageSize' => $pageSize,
  81. 'total' => isset($list['total']) ? $list['total'] : 0,
  82. 'list' => isset($list['data']) ? $list['data'] : []
  83. ];
  84. }
  85. /**
  86. * 选项列表
  87. * @param $userId
  88. * @return array|mixed
  89. */
  90. public function options($userId)
  91. {
  92. $cacheKey = "caches:members:banks:{$userId}";
  93. $datas = RedisService::get($cacheKey);
  94. if($datas){
  95. return $datas;
  96. }
  97. $datas = $this->model->where(['user_id'=> $userId,'status'=> 1,'mark'=>1])
  98. ->select(['id','realname','bank_name','bank_card','status'])
  99. ->get();
  100. $datas = $datas? $datas->toArrayu() :[];
  101. if($datas){
  102. RedisService::set($cacheKey, $datas, 7200);
  103. }
  104. return $datas;
  105. }
  106. /**
  107. * 保存数据
  108. * @param $userId
  109. * @param $params
  110. * @return mixed
  111. */
  112. public function saveData($userId, $params)
  113. {
  114. $id = isset($params['id']) ? $params['id'] : 0;
  115. $data = [
  116. 'user_id'=> $userId,
  117. 'realname'=> isset($params['realname'])? $params['realname'] : '',
  118. 'bank_name'=> isset($params['bank_name'])? $params['bank_name'] : '',
  119. 'bank_card'=> isset($params['bank_card'])? $params['bank_card'] : '',
  120. 'bank_code'=> isset($params['bank_code'])? $params['bank_code'] : '',
  121. 'status'=> isset($params['status'])? $params['status'] : 1,
  122. 'update_time'=> time(),
  123. 'mark'=> 1,
  124. ];
  125. if($id && $this->model->where(['id'=> $id])->value('id')){
  126. $this->model->where(['id'=> $id])->update($data);
  127. $this->error = $id? 1008 : 1027;
  128. return true;
  129. }else{
  130. $data['create_time'] = time();
  131. $this->error = 1027;
  132. return $this->model->insertGetId($data);
  133. }
  134. }
  135. /**
  136. * @return array|false
  137. */
  138. public function delete()
  139. {
  140. // 参数
  141. $id = request()->post('id');
  142. if (empty($id)) {
  143. $this->error = 2014;
  144. return false;
  145. }
  146. $this->error = 1002;
  147. $this->model->where(['mark'=>0])->where('update_time','<=', time() - 3*86400)->delete();
  148. return $this->model->where(['id'=> $id])->update(['mark'=> 0, 'update_time'=> time()]);
  149. }
  150. }