User.php 5.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163
  1. <?php
  2. /**
  3. *
  4. * @author: xaboy<365615158@qq.com>
  5. * @day: 2017/12/21
  6. */
  7. namespace app\routine\model\user;
  8. use basic\ModelBasic;
  9. use service\SystemConfigService;
  10. use think\Request;
  11. use think\Session;
  12. use traits\ModelTrait;
  13. /**
  14. * 用户model
  15. * Class User
  16. * @package app\routine\model\user
  17. */
  18. class User extends ModelBasic
  19. {
  20. use ModelTrait;
  21. public static function updateWechatUser($wechatUser,$uid)
  22. {
  23. return self::edit([
  24. 'nickname'=>$wechatUser['nickname']?:'',
  25. 'avatar'=>$wechatUser['headimgurl']?:'',
  26. 'last_time'=>time(),
  27. 'last_ip'=>Request::instance()->ip(),
  28. ],$uid,'uid');
  29. }
  30. /**
  31. * 小程序用户添加
  32. * @param $routineUser
  33. * @param int $spread_uid
  34. * @return object
  35. */
  36. public static function setRoutineUser($routineUser,$spread_uid = 0){
  37. return self::set([
  38. 'account'=>'rt'.$routineUser['uid'].time(),
  39. 'pwd'=>md5(123456),
  40. 'nickname'=>$routineUser['nickname']?:'',
  41. 'avatar'=>$routineUser['headimgurl']?:'',
  42. 'spread_uid'=>$spread_uid,
  43. 'uid'=>$routineUser['uid'],
  44. 'add_time'=>$routineUser['add_time'],
  45. 'add_ip'=>Request::instance()->ip(),
  46. 'last_time'=>time(),
  47. 'last_ip'=>Request::instance()->ip(),
  48. 'user_type'=>$routineUser['user_type']
  49. ]);
  50. }
  51. /**
  52. * 获得当前登陆用户UID
  53. * @return int $uid
  54. */
  55. public static function getActiveUid()
  56. {
  57. $uid = null;
  58. $uid = Session::get('LoginUid');
  59. if($uid) return $uid;
  60. else return 0;
  61. }
  62. public static function getUserInfo($uid)
  63. {
  64. $userInfo = self::where('uid',$uid)->find();
  65. if(!$userInfo) exception('读取用户信息失败!');
  66. return $userInfo->toArray();
  67. }
  68. /**
  69. * 判断当前用户是否推广员
  70. * @param int $uid
  71. * @return bool
  72. */
  73. public static function isUserSpread($uid = 0){
  74. if(!$uid) return false;
  75. $status = (int)SystemConfigService::get('store_brokerage_statu');
  76. $isPromoter = true;
  77. if($status == 1) $isPromoter = self::where('uid',$uid)->value('is_promoter');
  78. if($isPromoter) return true;
  79. else return false;
  80. }
  81. /**
  82. * 小程序用户一级分销
  83. * @param $orderInfo
  84. * @return bool
  85. */
  86. public static function backOrderBrokerage($orderInfo)
  87. {
  88. $userInfo = User::getUserInfo($orderInfo['uid']);
  89. if(!$userInfo || !$userInfo['spread_uid']) return true;
  90. $storeBrokerageStatu = SystemConfigService::get('store_brokerage_statu') ? : 1;//获取后台分销类型
  91. if($storeBrokerageStatu == 1){
  92. if(!User::be(['uid'=>$userInfo['spread_uid'],'is_promoter'=>1])) return true;
  93. }
  94. $brokerageRatio = (SystemConfigService::get('store_brokerage_ratio') ?: 0)/100;
  95. if($brokerageRatio <= 0) return true;
  96. $cost = isset($orderInfo['cost']) ? $orderInfo['cost'] : 0;//成本价
  97. if($cost > $orderInfo['pay_price']) return true;//成本价大于支付价格时直接返回
  98. $brokeragePrice = bcmul(bcsub($orderInfo['pay_price'],$cost,2),$brokerageRatio,2);
  99. //返佣之后余额
  100. $balance = bcsub($userInfo['now_money'],$brokeragePrice,2);
  101. if($brokeragePrice <= 0) return true;
  102. $mark = $userInfo['nickname'].'成功消费'.floatval($orderInfo['pay_price']).'元,奖励推广佣金'.floatval($brokeragePrice);
  103. self::beginTrans();
  104. $res1 = UserBill::income('获得推广佣金',$userInfo['spread_uid'],'now_money','brokerage',$brokeragePrice,$orderInfo['id'],$balance,$mark);
  105. $res2 = self::bcInc($userInfo['spread_uid'],'now_money',$brokeragePrice,'uid');
  106. $res = $res1 && $res2;
  107. self::checkTrans($res);
  108. if($res) self::backOrderBrokerageTwo($orderInfo);
  109. return $res;
  110. }
  111. /**
  112. * 小程序 二级推广
  113. * @param $orderInfo
  114. * @return bool
  115. */
  116. public static function backOrderBrokerageTwo($orderInfo){
  117. $userInfo = User::getUserInfo($orderInfo['uid']);
  118. $userInfoTwo = User::getUserInfo($userInfo['spread_uid']);
  119. if(!$userInfoTwo || !$userInfoTwo['spread_uid']) return true;
  120. $storeBrokerageStatu = SystemConfigService::get('store_brokerage_statu') ? : 1;//获取后台分销类型
  121. if($storeBrokerageStatu == 1){
  122. if(!User::be(['uid'=>$userInfoTwo['spread_uid'],'is_promoter'=>1])) return true;
  123. }
  124. $brokerageRatio = (SystemConfigService::get('store_brokerage_two') ?: 0)/100;
  125. if($brokerageRatio <= 0) return true;
  126. $cost = isset($orderInfo['cost']) ? $orderInfo['cost'] : 0;//成本价
  127. if($cost > $orderInfo['pay_price']) return true;//成本价大于支付价格时直接返回
  128. $brokeragePrice = bcmul(bcsub($orderInfo['pay_price'],$cost,2),$brokerageRatio,2);
  129. //返佣之后余额
  130. $balance = bcsub($userInfo['now_money'],$brokeragePrice,2);
  131. if($brokeragePrice <= 0) return true;
  132. $mark = '二级推广人'.$userInfo['nickname'].'成功消费'.floatval($orderInfo['pay_price']).'元,奖励推广佣金'.floatval($brokeragePrice);
  133. self::beginTrans();
  134. $res1 = UserBill::income('获得推广佣金',$userInfoTwo['spread_uid'],'now_money','brokerage',$brokeragePrice,$orderInfo['id'],$balance,$mark);
  135. $res2 = self::bcInc($userInfoTwo['spread_uid'],'now_money',$brokeragePrice,'uid');
  136. $res = $res1 && $res2;
  137. self::checkTrans($res);
  138. return $res;
  139. }
  140. /**
  141. * TODO 订单删除 恢复对应的积分
  142. * @param $uid
  143. * @param $integral
  144. * @return bool
  145. */
  146. public static function recoverOrderIntegral($uid, $integral)
  147. {
  148. return self::bcInc($uid,'integral',$integral,'uid');
  149. }
  150. }