WelfareLoginc.php 5.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150
  1. <?php
  2. namespace app\api\logic;
  3. use app\api\controller\Product;
  4. use app\common\model\ProductArea;
  5. use app\common\controller\Api;
  6. use app\common\model\UserWelfare;
  7. use app\common\model\ProductPopular;
  8. use app\common\model\ProductOrder;
  9. use app\common\model\UserModel;
  10. use fast\Action;
  11. use fast\Asset;
  12. use fast\MembershipLevel;
  13. use think\Db;
  14. use think\Log;
  15. use think\Exception;
  16. use think\console\Output;
  17. use fast\Http;
  18. /**
  19. * 空投福利
  20. */
  21. class WelfareLoginc
  22. {
  23. /** 添加新人福利
  24. * @param int $uid 用户id
  25. * @param array $productId 产品ID
  26. * @param int $num 数量
  27. * @param int $lan 语言
  28. */
  29. public static function setUserWelfareLos($uid, int $productId, $num, $tim, $lan, $typeId)
  30. {
  31. $result = ProductPopular::getPopularByTime($productId, $lan, $tim);
  32. if(!$result || $num > ($result->stock-$result->init_num - $result->num)) throw new Exception(__('库存不足'));
  33. //echo 111;die;
  34. //添加产品
  35. self::setUserProductOrder($num, $result->is_area, $result->id, $result->price, $productId, $uid, $typeId);
  36. return ['start_time'=>$tim, 'name'=>$result->name, 'num'=>$num, 'price'=>$result->price];
  37. }
  38. /*
  39. 这个条件是
  40. 向持有选定产品超过指定数量的用户空投指定数量/或比例/的指定产品,
  41. 比如
  42. 向持有A茶超过10套的用户,空投2套B茶
  43. 向持有A茶超过10套的用户,空投持有 数量X20%套B茶,数量取整
  44. */
  45. /** $mod 0指定数量 1比
  46. * 获取用户Rwa数量
  47. */
  48. public static function getUserRwaProductNum(int $productId, int $rwa_num, $mod, $num): int
  49. {
  50. //读取当日新增数据
  51. $list = ProductOrder::where('product_id', $productId)->where('status', ProductOrder::Paid)->where('popular_price', '>', config('min_rwa_price'))
  52. ->field('user_id,sum(num) as total_num')
  53. ->group('user_id')
  54. ->field('user_id,count(num) as total_num')
  55. ->group('user_id')
  56. ->having('total_num>='.$rwa_num)->select();
  57. if(empty($list)) return 0;
  58. $total = 0; //总数量
  59. if($mod == 1 && $num > 0){
  60. $num = bcdiv($num, 100, 2);
  61. foreach ($list as $item) {
  62. $total += bcmul($item->total_num, $num);
  63. }
  64. }else{
  65. $total = count($list) * $num;
  66. }
  67. return $total;
  68. }
  69. /**
  70. * 向达到一定持有量的用户空投产品
  71. * @param int $rwa_num //数量
  72. * @param $productId //产品ID
  73. * @param $rwaProductId //Rwa产品ID
  74. * @param $isArea
  75. * @param $orderId
  76. * @param $price
  77. * @param $mod
  78. * @param $num
  79. * @return int
  80. */
  81. public static function setUserExRwaNum(int $rwa_num, $productId, $rwaProductId, $isArea, $orderId, $price, $mod, $num): int
  82. {
  83. $total = 0; //总数量
  84. // 使用bcdiv函数进行高精度除法运算,$num除以100,保留两位小数
  85. $div = bcdiv($num, 100, 2);
  86. $list = ProductOrder::where('status', ProductOrder::Paid)
  87. ->where('product_id', $rwaProductId)
  88. ->where('popular_price', '>', config('min_rwa_price'))
  89. ->group('user_id')->having('total_num>='.$rwa_num)
  90. ->field('id,user_id,count(num) as total_num')
  91. ->select();
  92. $user = new UserModel();
  93. foreach($list as $order){
  94. //根据$mod的值决定是否需要对用户的rwa_num进行乘以$div的运算
  95. $num = ($mod == 1)? bcmul($order->total_num, $div) : $num;
  96. // 尝试为用户设置产品订单,如果成功,则更新用户的rwa_num
  97. if(!empty(self::setUserProductOrder($num, $isArea, $orderId, $price, $productId, $order->user_id, ProductOrder::Airdrop))){
  98. // 调用静态方法更新用户的rwa_num,增加$num的值
  99. $user::updateForRwaNum($order->user_id, $user::getByParentId($order->user_id), $num, '+');
  100. }
  101. }
  102. return $total;
  103. }
  104. /**
  105. * 设置用户产品订单
  106. *
  107. * 该方法根据是否需要区域信息来设置用户的订单信息如果没有指定区域,则调用setPopularNoAreaOrder方法,
  108. * 否则,首先查询产品关联的区域ID,然后调用setPopularAreaOrder方法设置订单信息
  109. *
  110. * @param int $num 订单数量
  111. * @param bool $isArea 是否需要区域信息
  112. * @param mixed $orderId 订单ID
  113. * @param float $price 产品价格
  114. * @param int $productId 产品ID
  115. * @param int $uid 用户ID
  116. * @param int $typeId 订单类型ID
  117. *
  118. * @return mixed 返回订单设置结果
  119. */
  120. public static function setUserProductOrder(int $num, $isArea, $orderId, $price, $productId, $uid, $typeId)
  121. {
  122. // 判断是否需要区域信息
  123. if(empty($isArea)){
  124. // 不需要区域信息,调用相应的方法设置订单
  125. $result = ProductOrder::setPopularNoAreaOrder($num, $orderId, $price, $productId, $uid, $typeId);
  126. }else{
  127. // 需要区域信息,首先查询符合条件的区域ID
  128. $areaArr = ProductArea::where('product_id', $productId)->where('status', ProductArea::Normal)->orderRaw('id desc')->limit($num)->column('id');
  129. // 使用查询到的区域ID调用相应的方法设置订单
  130. $result = ProductOrder::setPopularAreaOrder($areaArr, $orderId, $price, $productId, $uid, $typeId);
  131. }
  132. // 返回订单设置结果
  133. return $result;
  134. }
  135. }