User.php 8.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265
  1. <?php
  2. // +----------------------------------------------------------------------
  3. // | 萤火商城系统 [ 致力于通过产品和服务,帮助商家高效化开拓市场 ]
  4. // +----------------------------------------------------------------------
  5. // | Copyright (c) 2017~2024 https://www.yiovo.com All rights reserved.
  6. // +----------------------------------------------------------------------
  7. // | Licensed 这不是一个自由软件,不允许对程序代码以任何形式任何目的的再发行
  8. // +----------------------------------------------------------------------
  9. // | Author: 萤火科技 <admin@yiovo.com>
  10. // +----------------------------------------------------------------------
  11. declare (strict_types=1);
  12. namespace app\store\model;
  13. use app\common\model\User as UserModel;
  14. use app\store\model\UserOauth as UserOauthModel;
  15. use app\store\model\user\GradeLog as GradeLogModel;
  16. use app\store\model\user\PointsLog as PointsLogModel;
  17. use app\store\model\user\BalanceLog as BalanceLogModel;
  18. use app\store\service\store\User as StoreUserService;
  19. use app\common\enum\user\balanceLog\Scene as SceneEnum;
  20. use app\common\enum\user\grade\log\ChangeType as ChangeTypeEnum;
  21. use app\common\library\helper;
  22. /**
  23. * 用户模型
  24. * Class User
  25. * @package app\store\model
  26. */
  27. class User extends UserModel
  28. {
  29. // 充值类型枚举: 余额
  30. const RECHARGE_TYPE_BALANCE = 'balance';
  31. // 充值类型枚举: 积分
  32. const RECHARGE_TYPE_POINTS = 'points';
  33. /**
  34. * 获取当前用户总数
  35. * @param array $param 查询参数
  36. * @return int|string
  37. */
  38. public function getUserTotal(array $param = [])
  39. {
  40. // 检索查询条件
  41. $filter = $this->getUserTotalFilter($param);
  42. // 查询结果
  43. return $this->where($filter)
  44. ->where('is_delete', '=', '0')
  45. ->count();
  46. }
  47. /**
  48. * 获取当前用户总数的查询条件
  49. * @param array $param
  50. * @return array
  51. */
  52. private function getUserTotalFilter(array $param = []): array
  53. {
  54. // 默认查询参数
  55. $params = $this->setQueryDefaultValue($param, [
  56. 'date' => null, // 注册日期 如: 2020-08-01
  57. 'isConsume' => null, // 是否已消费
  58. ]);
  59. // 检索查询条件
  60. $filter = [];
  61. if (!is_null($params['date'])) {
  62. $startTime = strtotime($params['date']);
  63. $filter[] = ['create_time', '>=', $startTime];
  64. $filter[] = ['create_time', '<', $startTime + 86400];
  65. }
  66. if (is_bool($params['isConsume'])) {
  67. $filter[] = ['pay_money', $params['isConsume'] ? '>' : '=', 0];
  68. }
  69. return $filter;
  70. }
  71. /**
  72. * 获取用户列表
  73. * @param array $param
  74. * @return \think\Paginator
  75. * @throws \think\db\exception\DbException
  76. */
  77. public function getList(array $param = []): \think\Paginator
  78. {
  79. // 检索查询条件
  80. $filter = $this->getFilter($param);
  81. // 获取用户列表
  82. return $this->with(['avatar', 'grade'])
  83. ->where($filter)
  84. ->where('is_delete', '=', '0')
  85. ->order(['create_time' => 'desc'])
  86. ->paginate(15);
  87. }
  88. /**
  89. * 获取查询条件
  90. * @param array $param
  91. * @return array
  92. */
  93. private function getFilter(array $param = []): array
  94. {
  95. // 默认查询条件
  96. $params = $this->setQueryDefaultValue($param, [
  97. 'search' => '', // 会员昵称
  98. 'gender' => -1, // 用户性别
  99. 'gradeId' => 0, // 用户等级
  100. ]);
  101. // 检索查询条件
  102. $filter = [];
  103. // 会员昵称
  104. !empty($params['search']) && $filter[] = ['nick_name|mobile', 'like', "%{$params['search']}%"];
  105. // 用户性别
  106. $params['gender'] > -1 && $filter[] = ['gender', '=', (int)$params['gender']];
  107. // 用户等级
  108. $params['gradeId'] > 0 && $filter[] = ['grade_id', '=', (int)$params['gradeId']];
  109. // 起止时间
  110. if (!empty($params['betweenTime'])) {
  111. $times = between_time($params['betweenTime']);
  112. $filter[] = ['create_time', '>=', $times['start_time']];
  113. $filter[] = ['create_time', '<', $times['end_time'] + 86400];
  114. }
  115. return $filter;
  116. }
  117. /**
  118. * 删除用户
  119. * @return false|mixed
  120. */
  121. public function setDelete()
  122. {
  123. return $this->transaction(function () {
  124. // 将第三方用户信息记录标记删除
  125. UserOauthModel::updateBase(['is_delete' => 1], [
  126. ['user_id', '=', $this['user_id']]
  127. ]);
  128. // 标记为已删除
  129. return $this->save(['is_delete' => 1]);
  130. });
  131. }
  132. /**
  133. * 用户充值
  134. * @param string $target 充值类型
  135. * @param array $data 表单数据
  136. * @return bool
  137. */
  138. public function recharge(string $target, array $data): bool
  139. {
  140. // 当前操作人用户名
  141. $storeUserName = StoreUserService::getLoginInfo()['user']['user_name'];
  142. if ($target === self::RECHARGE_TYPE_BALANCE) {
  143. return $this->rechargeToBalance($storeUserName, $data['balance']);
  144. } elseif ($target === self::RECHARGE_TYPE_POINTS) {
  145. return $this->rechargeToPoints($storeUserName, $data['points']);
  146. }
  147. return false;
  148. }
  149. /**
  150. * 用户充值:余额
  151. * @param string $storeUserName
  152. * @param array $data
  153. * @return bool
  154. */
  155. private function rechargeToBalance(string $storeUserName, array $data): bool
  156. {
  157. if (!isset($data['money']) || $data['money'] === '' || $data['money'] < 0) {
  158. $this->error = '请输入正确的金额';
  159. return false;
  160. }
  161. // 判断充值方式,计算最终金额
  162. if ($data['mode'] === 'inc') {
  163. $diffMoney = $data['money'];
  164. } elseif ($data['mode'] === 'dec') {
  165. $diffMoney = -$data['money'];
  166. } else {
  167. $diffMoney = helper::bcsub($data['money'], $this['balance']);
  168. }
  169. // 更新记录
  170. $this->transaction(function () use ($storeUserName, $data, $diffMoney) {
  171. // 更新账户余额
  172. static::setIncBalance((int)$this['user_id'], (float)$diffMoney);
  173. // 新增余额变动记录
  174. BalanceLogModel::add(SceneEnum::ADMIN, [
  175. 'user_id' => $this['user_id'],
  176. 'money' => (float)$diffMoney,
  177. 'remark' => $data['remark'],
  178. ], [$storeUserName]);
  179. });
  180. return true;
  181. }
  182. /**
  183. * 用户充值:积分
  184. * @param string $storeUserName
  185. * @param array $data
  186. * @return bool
  187. */
  188. private function rechargeToPoints(string $storeUserName, array $data): bool
  189. {
  190. if (!isset($data['value']) || $data['value'] === '' || $data['value'] < 0) {
  191. $this->error = '请输入正确的积分数量';
  192. return false;
  193. }
  194. // 判断充值方式,计算最终积分
  195. if ($data['mode'] === 'inc') {
  196. $diffMoney = $data['value'];
  197. } elseif ($data['mode'] === 'dec') {
  198. $diffMoney = -$data['value'];
  199. } else {
  200. $diffMoney = $data['value'] - $this['points'];
  201. }
  202. // 更新记录
  203. $this->transaction(function () use ($storeUserName, $data, $diffMoney) {
  204. // 更新账户积分
  205. $this->setInc($this['user_id'], 'points', $diffMoney);
  206. // 新增积分变动记录
  207. PointsLogModel::add([
  208. 'user_id' => $this['user_id'],
  209. 'value' => $diffMoney,
  210. 'describe' => "后台管理员 [{$storeUserName}] 操作",
  211. 'remark' => $data['remark'],
  212. ]);
  213. });
  214. return true;
  215. }
  216. /**
  217. * 修改用户等级
  218. * @param array $data
  219. * @return mixed
  220. */
  221. public function updateGrade(array $data)
  222. {
  223. // 变更前的等级id
  224. $oldGradeId = $this['grade_id'];
  225. return $this->transaction(function () use ($oldGradeId, $data) {
  226. // 更新用户的等级
  227. $status = $this->save(['grade_id' => $data['grade_id']]);
  228. // 新增用户等级修改记录
  229. if ($status) {
  230. (new GradeLogModel)->record([
  231. 'user_id' => $this['user_id'],
  232. 'old_grade_id' => $oldGradeId,
  233. 'new_grade_id' => $data['grade_id'],
  234. 'change_type' => ChangeTypeEnum::ADMIN_USER,
  235. 'remark' => $data['remark']
  236. ]);
  237. }
  238. return $status !== false;
  239. });
  240. }
  241. /**
  242. * 消减用户的实际消费金额
  243. * @param int $userId
  244. * @param float $expendMoney
  245. * @return mixed
  246. */
  247. public function setDecUserExpend(int $userId, float $expendMoney)
  248. {
  249. return $this->setDec(['user_id' => $userId], 'expend_money', $expendMoney);
  250. }
  251. }