CloudStockBonusPoolUser.php 3.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105
  1. <?php
  2. namespace addons\CloudStock\common\models;
  3. use common\enums\StatusEnum;
  4. use common\models\base\BaseActiveRecord;
  5. use common\models\user\User;
  6. use Yii;
  7. /**
  8. * This is the model class for table "qimall_addons_cloud_stock_bonus_pool_user".
  9. *
  10. * @property int $id
  11. * @property int $mall_id 商城ID
  12. * @property int $user_id 用户ID
  13. * @property int $level 等级(权重)
  14. * @property float $pool_income 分红池总收益,单位:元
  15. * @property int $upgrade_status 1条件升级,2购买指定商品升级,3手动升级
  16. * @property int $upgrade_level_at 等级升级时间
  17. * @property int $status 状态[-1:删除;0:禁用;1启用]
  18. * @property int|null $created_at 创建时间
  19. * @property int|null $updated_at 更新时间
  20. */
  21. class CloudStockBonusPoolUser extends BaseActiveRecord
  22. {
  23. /**
  24. * {@inheritdoc}
  25. */
  26. public static function tableName()
  27. {
  28. return '{{%addons_cloud_stock_bonus_pool_user}}';
  29. }
  30. /**
  31. * {@inheritdoc}
  32. */
  33. public function rules()
  34. {
  35. return [
  36. [['mall_id', 'user_id', 'level', 'upgrade_status', 'upgrade_level_at', 'status', 'created_at', 'updated_at'], 'integer'],
  37. [['pool_income'], 'number'],
  38. ];
  39. }
  40. /**
  41. * {@inheritdoc}
  42. */
  43. public function attributeLabels()
  44. {
  45. return [
  46. 'id' => 'ID',
  47. 'mall_id' => '商城ID',
  48. 'user_id' => '用户ID',
  49. 'level' => '等级(权重)',
  50. 'pool_income' => '分红池总收益,单位:元',
  51. 'upgrade_status' => '1条件升级,2购买指定商品升级,3手动升级',
  52. 'upgrade_level_at' => '等级升级时间',
  53. 'status' => '状态[-1:删除;0:禁用;1启用]',
  54. 'created_at' => '创建时间',
  55. 'updated_at' => '更新时间',
  56. ];
  57. }
  58. public function getUser()
  59. {
  60. return $this->hasOne(User::class, ['id' => 'user_id'])->select('id,mobile,nickname,avatar_url,parent_id');
  61. }
  62. public static function create($params)
  63. {
  64. try {
  65. $model = self::findOne(['user_id' => $params['user_id'], 'status' => StatusEnum::ENABLED]);
  66. if (empty($model)) {
  67. $model = new self();
  68. $model->loadDefaultValues();
  69. } else {
  70. // 如果非升级情况则不做任何保存或处理
  71. if ($model->level >= $params['level']) return $model->toArray();
  72. }
  73. if (!$model->load($params, '') || !$model->save()) throw new \Exception($model->getErrorMessage());
  74. return $model->toArray();
  75. } catch (\Exception $e) {
  76. self::setStaticError($e->getMessage());
  77. return false;
  78. }
  79. }
  80. public static function del($id, $mall_id)
  81. {
  82. try {
  83. $model = self::findOne(['id' => $id, 'mall_id' => $mall_id, 'status' => [StatusEnum::ENABLED, StatusEnum::DISABLED]]);
  84. if (empty($model)) {
  85. throw new \Exception('该分红用户不存在');
  86. }
  87. $model->status = StatusEnum::DELETE;
  88. if (!$model->save()) throw new \Exception($model->getErrorMessage());
  89. return $model->toArray();
  90. } catch (\Exception $e) {
  91. self::setStaticError($e->getMessage());
  92. return false;
  93. }
  94. }
  95. }