1
0

UserCouponLogic.php 7.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183
  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. if(isset($params['voucher_status']) && is_array($params['voucher_status'])){
  87. $where[] = ['voucher_status','IN',$params['voucher_status']];
  88. }
  89. $where[] = ['user_id','=',$params['user_id']];
  90. $data = UserCoupon::where($where)
  91. ->where(function(Query $query){
  92. $query->where(' expire_time >'. (time()-86400*7));
  93. })
  94. ->field(['id','code','amount','amount_require','begin_use','voucher_status','discount_ratio','event_name','expire_time','max_deductible_price','server_category_name','mold_type'])
  95. ->append(['voucher_status_text','discount_ratio_text'])
  96. ->order(['id' => 'desc'])
  97. ->select()
  98. ->toArray();
  99. $couponCodes = [];
  100. foreach($data as $k => $v){
  101. if($v['expire_time'] < time()){
  102. $couponCodes[] = $v['code'];
  103. $data[$k]['voucher_status_text'] = '已过期';
  104. }
  105. $data[$k]['begin_use'] = date("Y-m-d H:i:s",$v['begin_use'] );
  106. $data[$k]['expire_time'] = date("Y-m-d H:i:s",$v['expire_time'] );
  107. $data[$k]['amount_require'] = '满'.$v['amount_require'].'可用';
  108. }
  109. if(!empty($couponCodes)){
  110. UserCoupon::whereIn('code',$couponCodes)->update(['voucher_status'=>2]);
  111. }
  112. return $data;
  113. } catch (\Exception $e){
  114. Db::rollback();
  115. self::setError($e->getMessage());
  116. return false;
  117. }
  118. }
  119. /**
  120. * 商品分类优惠卷领取
  121. * @param $params
  122. * @return array|false
  123. */
  124. public static function categoryCouponLists($params)
  125. {
  126. try{
  127. $coupon_ids = CouponCategory::where('goods_category_id',$params['goods_category_id'])->column('coupon_id');
  128. $data = CouponRules::where('remaining_count','>',0)
  129. ->where('coupon_type',1)
  130. ->whereIn('id',$coupon_ids)
  131. ->where('voucher_status',1)
  132. ->append(['discount_ratio_text'])
  133. ->order(['id' => 'desc'])
  134. ->field(['code','amount','amount_require','discount_ratio','server_category_name',
  135. 'event_name','expire_time','max_deductible_price','mold_type',])
  136. ->select();
  137. foreach($data as $k => $v){
  138. $data[$k]['amount_require'] = '满'.$v['amount_require'].'可用';
  139. }
  140. $codes = $data->column('code');
  141. $userCouponCodes = [];
  142. if(!empty($code)){
  143. $userCouponCodes = UserCoupon::where('code',$codes)
  144. ->where('user_id',$params['user_id'])->column('code');
  145. }
  146. $data = $data->whereNotIn('code',$userCouponCodes)->toArray();
  147. return $data;
  148. }catch(\Exception $e){
  149. self::setError($e->getMessage());
  150. return false;
  151. }
  152. }
  153. public static function categoryWithAmountLists($params)
  154. {
  155. try{
  156. $data = UserCoupon::with(['couponCategory'=>function ($query) use ($params) {
  157. $query->where('goods_category_id',$params['goods_category_id']);
  158. }])->where('user_id',$params['user_id'])
  159. ->where('voucher_count','>',0)
  160. ->where('voucher_status',0)
  161. ->append(['discount_ratio_text'])
  162. ->where('amount_require','<=',$params['amount'])
  163. ->visible(['id','amount','amount_require','begin_use','discount_ratio','event_name','expire_time','max_deductible_price','server_category_name','mold_type'])
  164. ->select()->toArray();
  165. foreach($data as $k => $v){
  166. $data[$k]['begin_use'] = date("Y-m-d H:i:s",$v['begin_use'] );
  167. $data[$k]['expire_time'] = date("Y-m-d H:i:s",$v['expire_time'] );
  168. $data[$k]['amount_require'] = '满'.$v['amount_require'].'可用';
  169. }
  170. return $data;
  171. } catch(\Exception $e){
  172. self::setError($e->getMessage());
  173. return false;
  174. }
  175. }
  176. }