UserCouponLogic.php 7.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189
  1. <?php
  2. namespace app\api\logic;
  3. use app\common\logic\BaseLogic;
  4. use app\common\model\coupon\CouponCategory;
  5. use app\common\model\coupon\CouponRules;
  6. use app\common\model\coupon\UserCoupon;
  7. use think\db\Query;
  8. use think\db\Where;
  9. use think\Exception;
  10. use think\facade\Db;
  11. /**
  12. * @author 林海涛
  13. * @date 2024/7/18 下午4:49
  14. */
  15. class UserCouponLogic extends BaseLogic
  16. {
  17. public static function add($params)
  18. {
  19. Db::startTrans();
  20. try{
  21. $errMsgArr = [];
  22. $rules = CouponRules::whereIn('code',$params['codes'])->where('voucher_status',1)->lock(true)->select();
  23. $userCoupon = UserCoupon::where('user_id',$params['user_id'])
  24. ->whereIn('code',$params['codes'])
  25. ->where('voucher_count','>',0)
  26. ->select();
  27. if($rules->isEmpty()){
  28. $errMsgArr[] = '优惠券不存在';
  29. }
  30. $updateData = [];
  31. $createData = [];
  32. foreach($rules as $v) {
  33. if($v->voucher_status == 2){
  34. $errMsgArr[] = $v->event_name .'已设置为过期';
  35. continue;
  36. }
  37. if($v->remaining_count <= 0 ){
  38. $errMsgArr[] = $v->event_name .'数量不足';
  39. continue;
  40. }
  41. if($userCoupon->where('coupon_id',$v->id)->count()){
  42. $errMsgArr[] = $v->event_name . '已领取';
  43. continue;
  44. }
  45. $updateData[$v->id] = ['remaining_count' => --$v->remaining_count];
  46. $createData[] = [
  47. 'user_id'=>$params['user_id'],
  48. 'coupon_id' => $v->id,
  49. 'code' => $v->code,
  50. 'voucher_status' => 0,
  51. 'voucher_count' =>1,
  52. 'amount' => $v->mold_type != 1 ? $v->amount:null,
  53. 'amount_require' => $v->amount_require,
  54. 'begin_use' => time(),
  55. 'discount_ratio' => $v->mold_type == 1 ? $v->discount_ratio:null,
  56. 'event_name' => $v->event_name,
  57. 'expire_time' => time()+$v->expire_time,
  58. 'max_deductible_price' => $v->mold_type == 1 ? $v->max_deductible_price:null,
  59. 'mold_type' => $v->mold_type,
  60. 'server_category_name' => $v->server_category_name
  61. ];
  62. }
  63. if(!empty($updateData)){
  64. CouponRules::updateWhenCase($updateData);
  65. }
  66. if(!empty($createData)){
  67. (new UserCoupon())->saveAll($createData);
  68. }
  69. Db::commit();
  70. return $errMsgArr;
  71. }catch(\Exception $e){
  72. Db::rollback();
  73. self::setError($e->getMessage());
  74. return false;
  75. }
  76. }
  77. /**
  78. * 我的优惠卷列表
  79. * @param $params
  80. * @return array|false
  81. */
  82. public static function userCouponList($params)
  83. {
  84. try{
  85. $where = [];
  86. $where[] = ['voucher_status','=',0];
  87. if(isset($params['voucher_status']) && is_array($params['voucher_status'])){
  88. $where[] = ['voucher_status','IN',$params['voucher_status']];
  89. }
  90. $where[] = ['user_id','=',$params['user_id']];
  91. $data = UserCoupon::where($where)
  92. ->where(function(Query $query){
  93. $query->where(' expire_time >'. (time()-86400*7));
  94. })
  95. ->field(['id','code','amount','amount_require','begin_use','voucher_status','discount_ratio','event_name','expire_time','max_deductible_price','server_category_name','mold_type'])
  96. ->append(['voucher_status_text','discount_ratio_text'])
  97. ->order(['id' => 'desc'])
  98. ->select()
  99. ->toArray();
  100. $couponCodes = [];
  101. foreach($data as $k => $v){
  102. if($v['expire_time'] < time()){
  103. $couponCodes[] = $v['code'];
  104. $data[$k]['voucher_status_text'] = '已过期';
  105. }
  106. $data[$k]['begin_use'] = date("Y-m-d H:i:s",$v['begin_use'] );
  107. $data[$k]['expire_time'] = date("Y-m-d H:i:s",$v['expire_time'] );
  108. $data[$k]['amount_require'] = '满'.$v['amount_require'].'可用';
  109. }
  110. if(!empty($couponCodes)){
  111. UserCoupon::whereIn('code',$couponCodes)->update(['voucher_status'=>2]);
  112. }
  113. return $data;
  114. } catch (\Exception $e){
  115. Db::rollback();
  116. self::setError($e->getMessage());
  117. return false;
  118. }
  119. }
  120. /**
  121. * 商品分类优惠卷领取
  122. * @param $params
  123. * @return array|false
  124. */
  125. public static function categoryCouponLists($params)
  126. {
  127. try{
  128. $coupon_ids = CouponCategory::where('goods_category_id',$params['goods_category_id'])->column('coupon_id');
  129. $data = CouponRules::where('remaining_count','>',0)
  130. ->where('coupon_type',1)
  131. ->whereIn('id',$coupon_ids)
  132. ->where('voucher_status',1)
  133. ->append(['discount_ratio_text'])
  134. ->order(['id' => 'desc'])
  135. ->field(['code','amount','amount_require','discount_ratio','server_category_name',
  136. 'event_name','expire_time','max_deductible_price','mold_type',])
  137. ->select();
  138. foreach($data as $k => $v){
  139. $data[$k]['amount_require'] = '满'.$v['amount_require'].'可用';
  140. }
  141. $codes = $data->column('code');
  142. $userCouponCodes = [];
  143. if(!empty($code)){
  144. $userCouponCodes = UserCoupon::where('code',$codes)
  145. ->where('user_id',$params['user_id'])->column('code');
  146. }
  147. $data = $data->whereNotIn('code',$userCouponCodes)->toArray();
  148. return $data;
  149. }catch(\Exception $e){
  150. self::setError($e->getMessage());
  151. return false;
  152. }
  153. }
  154. public static function categoryWithAmountLists($params)
  155. {
  156. try{
  157. $coupon_all_ids =UserCoupon::where('user_id',$params['user_id'])
  158. ->where('voucher_count','>',0)
  159. ->where('voucher_status',0)
  160. ->where('amount_require','<=',$params['amount'])
  161. ->column('coupon_id');
  162. $coupon_ids = CouponCategory::where('goods_category_id',$params['goods_category_id'])->whereIn('coupon_id',$coupon_all_ids)->column('coupon_id');
  163. $data = UserCoupon::where('user_id',$params['user_id'])
  164. ->whereIn('coupon_id',$coupon_ids)
  165. ->append(['discount_ratio_text'])
  166. ->visible(['id','coupon_id','amount','amount_require','begin_use','discount_ratio','event_name','expire_time','max_deductible_price','server_category_name','mold_type'])
  167. ->select()->toArray();
  168. foreach($data as $k => $v){
  169. $data[$k]['begin_use'] = date("Y-m-d H:i:s",$v['begin_use'] );
  170. $data[$k]['expire_time'] = date("Y-m-d H:i:s",$v['expire_time'] );
  171. $data[$k]['amount_require'] = '满'.$v['amount_require'].'可用';
  172. }
  173. return $data;
  174. } catch(\Exception $e){
  175. self::setError($e->getMessage());
  176. return false;
  177. }
  178. }
  179. }