Grade.php 1.9 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970
  1. <?php
  2. namespace app\task\behavior\user;
  3. use think\Cache;
  4. use app\task\model\User as UserModel;
  5. use app\task\model\user\Grade as GradeModel;
  6. class Grade
  7. {
  8. /* @var GradeModel $model */
  9. private $model;
  10. /**
  11. * 执行函数
  12. * @param $model
  13. * @return bool
  14. * @throws \Exception
  15. */
  16. public function run($model)
  17. {
  18. if (!$model instanceof GradeModel) {
  19. return new GradeModel and false;
  20. }
  21. $this->model = $model;
  22. if (!$model::$wxapp_id) {
  23. return false;
  24. }
  25. $cacheKey = "__task_space__[user/Grade]__{$model::$wxapp_id}";
  26. if (!Cache::has($cacheKey)) {
  27. // 设置用户的会员等级
  28. $this->setUserGrade();
  29. Cache::set($cacheKey, time(), 60 * 10);
  30. }
  31. return true;
  32. }
  33. /**
  34. * 设置用户的会员等级
  35. * @return array|bool|false
  36. * @throws \Exception
  37. */
  38. private function setUserGrade()
  39. {
  40. // 用户模型
  41. $UserModel = new UserModel;
  42. // 获取所有等级
  43. $list = GradeModel::getUsableList(null, ['weight' => 'desc']);
  44. if ($list->isEmpty()) {
  45. return false;
  46. }
  47. // 遍历等级,根据升级条件 查询满足消费金额的用户列表,并且他的等级小于该等级
  48. $data = [];
  49. foreach ($list as $grade) {
  50. $userList = $UserModel->getUpgradeUserList($grade, array_keys($data));
  51. foreach ($userList as $user) {
  52. if (!isset($data[$user['user_id']])) {
  53. $data[$user['user_id']] = [
  54. 'user_id' => $user['user_id'],
  55. 'old_grade_id' => $user['grade_id'],
  56. 'new_grade_id' => $grade['grade_id'],
  57. ];
  58. }
  59. }
  60. }
  61. // 批量修改会员的等级
  62. return $UserModel->setBatchGrade($data);
  63. }
  64. }