WelfareLoginc.php 5.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140
  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) throw new Exception(__('库存不足'));
  33. //添加产品
  34. self::setUserProductOrder($num, $result->is_area, $result->id, $result->price, $productId, $uid, $typeId);
  35. return ['start_time'=>$tim, 'name'=>$result->name, 'num'=>$num, 'price'=>$result->price];
  36. }
  37. /*
  38. 这个条件是
  39. 向持有选定产品超过指定数量的用户空投指定数量/或比例/的指定产品,
  40. 比如
  41. 向持有A茶超过10套的用户,空投2套B茶
  42. 向持有A茶超过10套的用户,空投持有 数量X20%套B茶,数量取整
  43. */
  44. /** $mod 0指定数量 1比
  45. * 获取用户Rwa数量
  46. */
  47. public static function getUserRwaProductNum(int $productId, int $rwa_num, $mod, $num): int
  48. {
  49. //读取当日新增数据
  50. $list = ProductOrder::where('product_id', $productId)->where('status', ProductOrder::Paid)->where('popular_price', '>', config('min_rwa_price'))
  51. ->field('user_id,sum(num) as total_num')
  52. ->group('user_id')
  53. ->field('user_id,count(num) as total_num')
  54. ->group('user_id')
  55. ->having('total_num>='.$rwa_num)->select();
  56. if(empty($list)) return 0;
  57. $total = 0; //总数量
  58. if($mod == 1 && $num > 0){
  59. $num = bcdiv($num, 100, 2);
  60. foreach ($list as $item) {
  61. $total += bcmul($item->total_num, $num);
  62. }
  63. }else{
  64. $total = count($list) * $num;
  65. }
  66. return $total;
  67. }
  68. //空投Rwa发放
  69. public static function setUserExRwaNum(int $rwa_num, $productId, $rwaProductId, $isArea, $orderId, $price, $mod, $num): int
  70. {
  71. $total = 0; //总数量
  72. // 使用bcdiv函数进行高精度除法运算,$num除以100,保留两位小数
  73. $div = bcdiv($num, 100, 2);
  74. $list = ProductOrder::where('status', ProductOrder::Paid)->where('product_id', $rwaProductId)->where('popular_price', '>', config('min_rwa_price'))
  75. ->group('user_id')->having('total_num>='.$rwa_num)
  76. ->field('id,user_id,count(num) as total_num')->select();
  77. $user = new UserModel();
  78. foreach($list as $order){
  79. //根据$mod的值决定是否需要对用户的rwa_num进行乘以$div的运算
  80. $num = ($mod == 1)? bcmul($order->total_num, $div) : $num;
  81. // 尝试为用户设置产品订单,如果成功,则更新用户的rwa_num
  82. if(!empty(self::setUserProductOrder($num, $isArea, $orderId, $price, $productId, $order->user_id, ProductOrder::Airdrop))){
  83. // 调用静态方法更新用户的rwa_num,增加$num的值
  84. $user::updateForRwaNum($order->user_id, $user::getByParentId($order->user_id), $num, '+');
  85. }
  86. }
  87. return $total;
  88. }
  89. /**
  90. * 设置用户产品订单
  91. *
  92. * 该方法根据是否需要区域信息来设置用户的订单信息如果没有指定区域,则调用setPopularNoAreaOrder方法,
  93. * 否则,首先查询产品关联的区域ID,然后调用setPopularAreaOrder方法设置订单信息
  94. *
  95. * @param int $num 订单数量
  96. * @param bool $isArea 是否需要区域信息
  97. * @param mixed $orderId 订单ID
  98. * @param float $price 产品价格
  99. * @param int $productId 产品ID
  100. * @param int $uid 用户ID
  101. * @param int $typeId 订单类型ID
  102. *
  103. * @return mixed 返回订单设置结果
  104. */
  105. private static function setUserProductOrder(int $num, $isArea, $orderId, $price, $productId, $uid, $typeId)
  106. {
  107. // 判断是否需要区域信息
  108. if(empty($isArea)){
  109. // 不需要区域信息,调用相应的方法设置订单
  110. $result = ProductOrder::setPopularNoAreaOrder($num, $orderId, $price, $productId, $uid, $typeId);
  111. }else{
  112. // 需要区域信息,首先查询符合条件的区域ID
  113. $areaArr = ProductArea::where('product_id', $productId)->where('status', ProductArea::NORMAL)->orderRaw('id desc')->limit($num)->column('id');
  114. // 使用查询到的区域ID调用相应的方法设置订单
  115. $result = ProductOrder::setPopularAreaOrder($areaArr, $orderId, $price, $productId, $uid, $typeId);
  116. }
  117. // 返回订单设置结果
  118. return $result;
  119. }
  120. }