BusinessBonusUser.php 9.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240
  1. <?php
  2. namespace addons\BusinessBonus\common\models;
  3. use addons\BusinessBonus\common\enums\BusinessBonusEnums;
  4. use common\enums\StatusEnum;
  5. use common\models\common\Addons;
  6. use common\models\mall\MallAddons;
  7. use common\models\user\User;
  8. use Yii;
  9. /**
  10. * This is the model class for table "{{%addons_business_bonus_user}}".
  11. *
  12. * @property int $id
  13. * @property int $mall_id 商城ID
  14. * @property int|null $user_id 用户ID
  15. * @property int|null $business_bonus_level 招商分红等级ID
  16. * @property float|null $history_bonus_amount 历史累计分红
  17. * @property int|null $register_time 成为招商员时间
  18. * @property int|null $store_number 推广的门店数量
  19. * @property int|null $mch_number 推广的供应商数量
  20. * @property int|null $status 状态:-1删除,0禁用,1启用
  21. * @property int|null $created_at 创建时间
  22. * @property int|null $updated_at 更新时间
  23. */
  24. class BusinessBonusUser extends \common\models\base\BaseActiveRecord
  25. {
  26. /**
  27. * {@inheritdoc}
  28. */
  29. public static function tableName()
  30. {
  31. return '{{%addons_business_bonus_user}}';
  32. }
  33. /**
  34. * {@inheritdoc}
  35. */
  36. public function rules()
  37. {
  38. return [
  39. [['mall_id', 'user_id', 'business_bonus_level', 'register_time', 'store_number', 'mch_number', 'status', 'created_at', 'updated_at'], 'integer'],
  40. [['history_bonus_amount'], 'number'],
  41. ];
  42. }
  43. /**
  44. * {@inheritdoc}
  45. */
  46. public function attributeLabels()
  47. {
  48. return [
  49. 'id' => 'ID',
  50. 'mall_id' => '商城ID',
  51. 'user_id' => '用户ID',
  52. 'business_bonus_level' => '招商分红等级ID',
  53. 'history_bonus_amount' => '历史累计分红',
  54. 'register_time' => '成为招商员时间',
  55. 'store_number' => '推广的门店数量',
  56. 'mch_number' => '推广的供应商数量',
  57. 'status' => '状态:-1删除,0禁用,1启用',
  58. 'created_at' => '创建时间',
  59. 'updated_at' => '更新时间',
  60. ];
  61. }
  62. public function getUser()
  63. {
  64. return $this->hasOne(User::class, ['id' => 'user_id'])->select('id,mobile,nickname,avatar_url,parent_id,username');
  65. }
  66. /**
  67. * 数据设置
  68. */
  69. public static function setData(array $params)
  70. {
  71. try{
  72. if (!isset($params['mall_id']) || empty($params['mall_id'])) throw new Exception('缺少商城ID');
  73. if (isset($params['id']) && !empty($params['id'])) {
  74. $model = self::findOne(['id' => $params['id'], 'mall_id' => $params['mall_id'], 'status' => [StatusEnum::ENABLED, StatusEnum::DISABLED]]);
  75. if(empty($model)) throw new Exception('招商员不存在或已删除');
  76. if (isset($params['history_bonus_amount'])) {
  77. $model->history_bonus_amount += $params['history_bonus_amount'];
  78. unset($params['history_bonus_amount']);
  79. }
  80. if (isset($params['store_number'])) {
  81. $model->store_number += $params['store_number'];
  82. unset($params['store_number']);
  83. }
  84. if (isset($params['mch_number'])) {
  85. $model->mch_number += $params['mch_number'];
  86. unset($params['mch_number']);
  87. }
  88. } else {
  89. $model = new self();
  90. $model->loadDefaultValues();
  91. $model->mall_id = $params['mall_id'];
  92. }
  93. if (!$model->load($params,'') || !$model->save()) throw new Exception($model->getErrorMessage());
  94. return $model;
  95. }catch(Exception $e){
  96. self::setStaticError($e->getMessage());
  97. return false;
  98. }
  99. }
  100. /**
  101. * 获取或初始化招商员信息
  102. */
  103. public static function getInfo($mall_id, $user)
  104. {
  105. $user_id = $user->id;
  106. $business_user = self::getOne([
  107. ['=', 'mall_id', $mall_id],
  108. ['>=', 'status', StatusEnum::DISABLED],
  109. ['=', 'user_id', $user_id]
  110. ], true);
  111. $is_business_user = $business_user ? 1 : 0;
  112. $condition = null;
  113. if ($is_business_user == 0) {
  114. $condition = BusinessBonusUpgradeCondition::getOne([
  115. ['=', 'mall_id', $mall_id],
  116. ['=', 'business_bonus_level', BusinessBonusEnums::FIRST_BUSINESS_LEVEL],
  117. ['=', 'status', StatusEnum::ENABLED],
  118. ], true);
  119. }
  120. $is_init = false;
  121. $upgrade_type = 0;
  122. if ($condition) {
  123. // $upgrade_type = $condition['upgrade_type'];
  124. if ($condition['is_condition_upgrade']) {
  125. $checked_condition_values = json_decode($condition['checked_condition_values'],true);
  126. $checked_condition_keys = json_decode($condition['checked_condition_keys'],true);
  127. if (in_array(1, $checked_condition_keys)) {
  128. $upgrade_type = BusinessBonusEnums::UPGRADE_TYPE_APPLY;
  129. }
  130. }
  131. // 无条件但需要推广者身份
  132. // if ($upgrade_type == BusinessBonusEnums::UPGRADE_TYPE_FREE && $user->is_inviter == 1) {
  133. if ($checked_condition_values['0']['is_need_conditional'] == 0 && $user->is_inviter == 1) {
  134. // 成为初级招商员
  135. $user_data = [
  136. 'user_id' => $user_id,
  137. 'business_bonus_level' => BusinessBonusEnums::FIRST_BUSINESS_LEVEL,
  138. 'mall_id' => $mall_id,
  139. 'status' => StatusEnum::ENABLED,
  140. 'register_time' => time()
  141. ];
  142. // 对应等级信息
  143. $level_info = BusinessBonusLevel::getOne([
  144. ['=', 'mall_id', $mall_id],
  145. ['=', 'level', $user_data['business_bonus_level']],
  146. ['>=', 'status', StatusEnum::DISABLED],
  147. ], true);
  148. $record = [
  149. 'mall_id' => $mall_id,
  150. 'user_id' => $user_id,
  151. 'business_bonus_level' => $user_data['business_bonus_level'],
  152. 'bonus_rate' => $level_info['bonus_rate'] ?? 0,
  153. 'upgrade_time' => time(),
  154. 'status' => StatusEnum::ENABLED,
  155. 'upgrade_type' => BusinessBonusEnums::UPGRADE_TYPE_FREE,
  156. 'extra_data' => json_encode([
  157. 'mark' => '无条件成为' . ($level_info['level_name'] ?? ''),
  158. ], JSON_UNESCAPED_UNICODE)
  159. ];
  160. $trans = Yii::$app->db->beginTransaction();
  161. try {
  162. $res = BusinessBonusUpgradeRecord::setData($record);
  163. if ($res == false) throw new Exception(BusinessBonusUpgradeRecord::getStaticError());
  164. $res = self::setData($user_data);
  165. if ($res == false) throw new Exception(self::getStaticError());
  166. $trans->commit();
  167. $is_init = true;
  168. } catch (Exception $e) {
  169. $trans->rollBack();
  170. }
  171. }
  172. }
  173. if ($is_init) {
  174. return self::getInfo($mall_id, $user);
  175. }
  176. if ($is_business_user) {
  177. $level_info = BusinessBonusLevel::getOne([
  178. ['=', 'mall_id', $mall_id],
  179. ['=', 'level', $business_user['business_bonus_level']],
  180. ['>=', 'status', StatusEnum::DISABLED],
  181. ], true);
  182. $business_user['level_name'] = $level_info['level_name'];
  183. $business_user['bonus_rate'] = $level_info['bonus_rate'];
  184. }
  185. $user_info = [
  186. 'nickname' => $user->nickname,
  187. 'avatar_url' => $user->avatar_url,
  188. 'id' => $user->id,
  189. ];
  190. return compact('business_user', 'is_business_user', 'upgrade_type', 'user_info');
  191. }
  192. /**
  193. * @desc:推广中心-调用
  194. * @param $params ['user_id' => 1, 'mall_id' => 5, 'addons_name' => 'Agent']
  195. * @return array
  196. */
  197. public static function getIncomeInfo(array $params){
  198. $is_install = MallAddons::isInstall($params['mall_id'], $params['addons_name']);
  199. $data['total_commission'] = 0;
  200. $data['is_install'] = 0;
  201. $basic = \Yii::$app->services->setting->addons->get($params['mall_id'], $params['addons_name'], 'basic');
  202. $data['is_show_at_center'] = 1;
  203. if(isset($basic['is_show_at_center'])) $data['is_show_at_center'] = $basic['is_show_at_center'];
  204. if($is_install){
  205. $model = self::findOne(['user_id' => $params['user_id'], 'mall_id' => $params['mall_id']]);
  206. $data['total_commission'] = $model['history_bonus_amount'] ?? 0;
  207. $data['is_install'] = $is_install;
  208. }
  209. return $data;
  210. }
  211. public static function getAddons(array $params){
  212. $addons_name = $params['addons_name'];
  213. $is_install = MallAddons::isInstall($params['mall_id'], $addons_name);
  214. if($is_install){
  215. $detail = Addons::getOne([['name' =>$addons_name], ['is_online' => 1]], true,);
  216. return [
  217. 'addons_name'=>$addons_name,
  218. 'title'=>$detail['title'],
  219. ];
  220. }
  221. return [];
  222. }
  223. }