Users-back.php 2.7 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495
  1. <?php
  2. namespace app\common\model;
  3. use think\Db;
  4. use think\Model;
  5. /**
  6. * 会员模型
  7. */
  8. class Users extends Model
  9. {
  10. // 开启自动写入时间戳字段
  11. protected $autoWriteTimestamp = 'int';
  12. // 定义时间戳字段名
  13. protected $createTime = 'createtime';
  14. protected $updateTime = 'updatetime';
  15. public static function getByCodeAndMobile($code, $mobile)
  16. {
  17. $info = self::where('code', $code)
  18. ->where('mobile', $mobile)
  19. ->find();
  20. return $info;
  21. }
  22. /**
  23. * 变更会员余额
  24. * @param int $money 余额
  25. * @param int $user_id 会员ID
  26. * @param string $memo 备注
  27. */
  28. public static function money($money, $user_id, $memo)
  29. {
  30. Db::startTrans();
  31. try {
  32. $user = self::lock(true)->find($user_id);
  33. if ($user && $money != 0) {
  34. $before = $user->money;
  35. //$after = $user->money + $money;
  36. $after = function_exists('bcadd') ? bcadd($user->money, $money, 2) : $user->money + $money;
  37. //更新会员信息
  38. $user->save(['money' => $after]);
  39. //写入日志
  40. MoneyLog::create(['user_id' => $user_id, 'money' => $money, 'before' => $before, 'after' => $after, 'memo' => $memo]);
  41. }
  42. Db::commit();
  43. } catch (\Exception $e) {
  44. Db::rollback();
  45. }
  46. }
  47. /**
  48. * 变更会员积分
  49. * @param int $score 积分
  50. * @param int $user_id 会员ID
  51. * @param string $memo 备注
  52. */
  53. public static function score($score, $user_id, $memo)
  54. {
  55. Db::startTrans();
  56. try {
  57. $user = self::lock(true)->find($user_id);
  58. if ($user && $score != 0) {
  59. $before = $user->score;
  60. $after = $user->score + $score;
  61. $level = self::nextlevel($after);
  62. //更新会员信息
  63. $user->save(['score' => $after, 'level' => $level]);
  64. //写入日志
  65. ScoreLog::create(['user_id' => $user_id, 'score' => $score, 'before' => $before, 'after' => $after, 'memo' => $memo]);
  66. }
  67. Db::commit();
  68. } catch (\Exception $e) {
  69. Db::rollback();
  70. }
  71. }
  72. /**
  73. * 根据积分获取等级
  74. * @param int $score 积分
  75. * @return int
  76. */
  77. public static function nextlevel($score = 0)
  78. {
  79. $lv = array(1 => 0, 2 => 30, 3 => 100, 4 => 500, 5 => 1000, 6 => 2000, 7 => 3000, 8 => 5000, 9 => 8000, 10 => 10000);
  80. $level = 1;
  81. foreach ($lv as $key => $value) {
  82. if ($score >= $value) {
  83. $level = $key;
  84. }
  85. }
  86. return $level;
  87. }
  88. }