diff --git a/app/controller/api/Coupon.php b/app/controller/api/Coupon.php index 2df760e..f2df94e 100644 --- a/app/controller/api/Coupon.php +++ b/app/controller/api/Coupon.php @@ -1,3 +1,4 @@ +<<<<<<< HEAD request->param('page/d', 1); + $size = $this->request->param('size/d', 10); + //$type = $this->request->param('type', ''); + + $page = $page < 1 ? 1 : $page; + $size = $size < 1 ? 10 : $size; + $accountCode = $this->request->user['user_code'] ?? ''; + + + try { + $whereMap = []; + $sortOrder = ['is_verificated'=>'asc','id' => 'desc']; + $fields = [ + 'id', + 'is_verificated as isVerificated', + 'type_name', + 'money', + 'name as couponName', + 'business_code', + 'business_code as businessCode', + 'coupon_id', + 'end_time as endTime', + 'consumer_name as consumerName', + 'verificate_time as verificateTime', + '(end_time > NOW()) as sort_weight']; + + $whereMap[] = ['consumer_code', '=', $accountCode]; + + +// switch ($type) { +// case 'all': +// // 全部持有优惠券 +// $sortOrder = ['sort_weight' => 'desc', 'end_time' => 'asc']; +// break; +// case 'notUsed': +// // 未使用（包含已过期） +// $whereMap[] = ['is_verificated', '=', self::BOOL_FALSE]; +// $sortOrder = ['sort_weight' => 'desc', 'end_time' => 'asc']; +// break; +// case 'normal': +// // 未使用且未过期 +// $whereMap[] = ['is_verificated', '=', self::BOOL_FALSE]; +// $whereMap[] = ['end_time', '> TIME', date('Y-m-d H:i:s')]; +// break; +// case 'used': +// // 已使用 +// $whereMap[] = ['is_verificated', '=', self::BOOL_TRUE]; +// $sortOrder = ['verificate_time' => 'desc']; +// break; +// } + + + $res = CouponRepository::getInstance()->findList($whereMap, $fields, $page, $size,function ($q){ + return $q->with([ + "couponMain" => function ($q) { + $q->field("id,name,image_url,type_name"); + }, + "scoreModel", + "business" => function ($q) { + $q->field("code,id,business_name,business_subtitle"); + } + ]) + ->where(function ($q){ + $notUsedWhereMap = [];//未过期 未使用 + $notUsedWhereMap[] = ['is_verificated', '=', self::BOOL_FALSE]; + $notUsedWhereMap[] = ['end_time', '> TIME', date('Y-m-d H:i:s')]; + + $usedWhereMap = [];//已使用 7天内 + $usedWhereMap[] = ['is_verificated', '=', self::BOOL_TRUE]; + $usedWhereMap[] = ['verificate_time', '> TIME', date('Y-m-d H:i:s',time() - (7 * 86400)) ]; + + $beOverdueWhereMap = [];//未使用 已过期7天内 + $beOverdueWhereMap[] = ['is_verificated', '=', self::BOOL_FALSE]; + $beOverdueWhereMap[] = ['end_time', '> TIME', date('Y-m-d H:i:s',time() - (7 * 86400))];; + + + $q->whereOr(function ($q)use($notUsedWhereMap){ + $q->where($notUsedWhereMap); + })//未使用未过期 + + ->whereOr(function ($q)use($usedWhereMap){ + $q->where($usedWhereMap); + })//已使用 7天内 + + + ->whereOr(function ($q)use($usedWhereMap){ + $q->where($usedWhereMap); + });//已过期 + }) + //->fetchSql(true) + ; + }, $sortOrder); + + $time = time(); + $res['list'] ->each(function ($item) use($time){ + //重置优惠券名称 + if(isset($item->couponMain) && $item->couponMain){ + $item->couponName = $item->couponMain->name; + $item->image_url = $this->request->domain() . $item->couponMain->image_url; + }else{ + $item->image_url = $this->request->domain() . ''; + } + //是否已经打分过了 + if(isset($item->scoreModel) && $item->scoreModel){ + $item->scored = true; + $item->score = $item->scoreModel->score; + }else{ + $item->scored = false; + $item->score = Score::COMMON_OFF; + } + + + //到期状态 + //$expirationStr = ''; + $status = CouponModel::status_success;//默认未使用 + $endTime = strtotime($item->endTime); + $ExpirationTime = abs(($endTime - $time) / 86400); + if (($endTime > $time) ) { + $expirationStr = "还有".ceil($ExpirationTime)."天过期"; + } else { + $status = CouponModel::status_be_overdue; + $expirationStr = "已过期" . ceil($ExpirationTime) . "天"; + } + $item->expirationStr = $expirationStr; + if($item->isVerificated == CouponModel::is_verificated_on){ + $status = CouponModel::status_used; + } + + $item->status = $status; + + + //商家简称 + if(!empty($item->business)){ + $item->business_subtitle = $item->business->business_subtitle; + }else{ + $item->business_subtitle = ''; + } + + //图片 + if(!empty($item->business)){ + $item->business_subtitle = $item->business->business_subtitle; + }else{ + $item->business_subtitle = ''; + } + + }); + + $res['list'] = multiTwoArrayKeysExcludeFilter($res['list']->toArray(), ['sort_weight']); + return $this->json(0, 'success', $res); + } catch (RepositoryException | \Exception $e) { + return $this->json(5001, '优惠卷查询失败！'); + } + } + + /** + * 我的优惠卷列表 指定商家 未验证 + * + */ + public function getCouponListByBusinessCode() + { + $page = $this->request->param('page/d', 1); + $size = $this->request->param('size/d', 10); + $businessCode = $this->request->param('business_code/s', ''); + + + $page = $page < 1 ? 1 : $page; + $size = $size < 1 ? 10 : $size; + $accountCode = $this->request->user['user_code'] ?? ''; + $time = time(); + + try { + $whereMap = []; + $fields = [ + 'id', + 'coupon_id', + 'business_code', + 'is_verificated as isVerificated', + 'money', + 'name as couponName', + 'business_code as businessCode', + 'end_time as endTime', + 'consumer_name as consumerName', + 'verificate_time as verificateTime', + '(end_time > NOW()) as sort_weight']; + + $whereMap[] = ['consumer_code', '=', $accountCode]; + $whereMap[] = ['business_code', '=', $businessCode]; + $whereMap[] = ['is_verificated', '=', CouponModel::is_verificated_off]; + $whereMap[] = ['end_time', '> TIME', date("Y-m-d H:i:s")]; + $sortOrder = ['sort_weight' => 'desc', 'end_time' => 'asc']; + + $res = CouponRepository::getInstance()->findList($whereMap, $fields, $page, $size,function ($q){ + return $q->with( + [ + "couponMain" => function ($q) { + $q->field("id,name,image_url,type_name"); + }, + "scoreModel", + "business" => function ($q) { + $q->field("id,code,business_name,business_subtitle"); + } + ]); + }, $sortOrder); + + $res['list'] ->each(function ($item) use($time){ + + //重置过期时间 + $item->endTimeText = date("Y-m-d",strtotime($item->endTime)); + + $status = CouponModel::status_success;//默认未使用 + $endTime = strtotime($item->endTime); + $ExpirationTime = abs(($endTime - $time) / 86400); + if (($endTime > $time) ) { + $expirationStr = "还有".ceil($ExpirationTime)."天过期"; + } else { + $status = CouponModel::status_be_overdue; + $expirationStr = "已过期" . ceil($ExpirationTime) . "天"; + } + $item->expirationStr = $expirationStr; + if($item->isVerificated == CouponModel::is_verificated_on){ + $status = CouponModel::status_used; + } + + $item->status = $status; + + //重置优惠券名称 + if(isset($item->couponMain) && $item->couponMain){ + $item->couponName = $item->couponMain->name; + $item->image_url = $this->request->domain() . $item->couponMain->image_url; + }else{ + $item->image_url = $this->request->domain() . ''; + } + + }); + + $res['list'] = multiTwoArrayKeysExcludeFilter($res['list']->toArray(), ['sort_weight']); + return $this->json(0, 'success', $res); + } catch (RepositoryException | \Exception $e) { + return $this->json(5001, '优惠卷查询失败！'); + } + } + + /** + * 领取优惠券 + * */ + public function receiveCoupon() + { + $accountId = $this->request->user['user_id'] ?? 0; + $lat = input("lat/f",0); + $lng = input("lng/f",0); + $distributionUserCode = input("distribution_user_code/s",''); + $account = AccountRepository::getInstance()->findById($accountId, [], function ($q) { + return $q->with(['business', 'parent']); + }); + if(empty($account)){ + return $this->json(6001,"无效的用户"); + } + + if ($lat <= 0 || $lng <= 0) { + return $this->json(4001, "请授权定位"); + } + + $couponMainId = input("couponId/d", 0); + $couponMain = CouponMain::findOne(["id" => $couponMainId],[],function ($q){ + //执行领取 开启锁 + return $q->with("business")->lock(true); + }); + if(!isset($couponMain->business)||empty($couponMain->business)){ + return $this->json(4001, "优惠券所属商家不存在"); + } + + if($couponMain->business->enable != BusinessModel::COMMON_OFF){ + return $this->json(4001, "商家已禁用"); + } + + try { + //检查优惠券状态 + CouponRepository::getInstance()->checkCouponMainReceiveStatus($couponMain); + }catch (RepositoryException $e){ + return $this->json(4001,$e->getMessage()); + } + + + try { + //检查是否可以领取 0可领取 1已领取 + AccountRepository::getInstance()->getCouponReceiveStatusText($account,$couponMain);//领取状态 + }catch (RepositoryException $e){ + return $this->json(4001,$e->getMessage()); + } + + + //检查通过 执行领取 + $time = time(); + Db::startTrans(); + try { + //写入领取记录 + $data = [ + "coupon_id" =>$couponMain->id, + "name" =>$couponMain["name"], + "type_id" =>$couponMain->type, + "type_name" =>$couponMain->type_name, + "business_code" =>$couponMain->business_code, + "business_name" =>$couponMain->business?$couponMain->business->business_name:'', + "consumer_code" =>$account->user_code, + "consumer_name" =>$account->nick_name, + "money" => $couponMain->money, + "content" => createUuid(),//未知作用 + "received_time" => date("Y-m-d H:i:s",$time), + "lat" => $lat, + "lng" => $lng, + "end_time" => date($couponMain->end_time . " 00:00:00"), + "edition" => couponMain::COMMON_ON,//版本 未知作用 + "is_verificated" => couponMain::COMMON_OFF,//是否验证 + "distribution_user_code" => $distributionUserCode,//分销人user_code + ]; + + CouponRepository::getInstance()->receiveCoupon($data); + $couponMain->save(["received_count"=>Db::raw("received_count + 1")]); + + + + + //是否开启分销 并且有分销人 给分销人发红包 + if($couponMain->is_distribution == CouponMain::COMMON_ON && !empty($distributionUserCode)) + { + $distributionUser = Account::findOne([["user_code","=",$distributionUserCode]]); + if(empty($distributionUser)){ + Db::rollback(); + return $this->json(4001,"分享人不存在"); + } + $payment = WechatPay::getInstance(); + $distributionRedpack = Redpack::getDistributionRedpack($distributionUserCode,$couponMainId,$account->user_code); + //如果付款过一次了 就用同一个订单号发起 + if(!empty($distributionRedpack)){ + $mch_billno = $distributionRedpack->mch_billno; + }else{ + $mch_billno = createUuid(); + } + + $amount = (($couponMain->deduction_money / 100) * $couponMain->commission_dis_distribution); + $amount = round($amount,2); //四舍五入 精确到分 + + $toBalanceData = [ + 'partner_trade_no' => $mch_billno,// 商户订单号，需保持唯一性(只能是字母或者数字，不能包含有符号) + 'openid' => $account->open_id, + 'check_name' => 'NO_CHECK',// NO_CHECK：不校验真实姓名, FORCE_CHECK：强校验真实姓名 + 'amount' => $amount * 100, //单位为分，不小于100 + 'desc' => '优惠券分销,分销者领取奖励', + ]; + + // 写入红包 + $redpackData = [ + "coupon_id" => 0, + "mch_billno" => $mch_billno, + "openid" => $distributionUser->open_id, + "user_code" => $distributionUser->user_code, + "money" => $amount, + "create_time" => date("Y-m-d H:i:s",$time), + "pay_time" => '0000-00-00 00:00:00', + + "user_type" => Redpack::userTypeDistribution, + "distributed_user_code" => $account->user_code, + "distributed_coupon_main_id" => $couponMainId, + ]; + + + //发起支付 + $result = $payment->transfer->toBalance($toBalanceData); + + //var_dump($result); + + //付款成功才提交！！！！！伪装成功 + if( isset($result['payment_no']) ){ + $redpackData['pay_time'] = date("Y-m-d H:i:s",$time); + Redpack::create($redpackData); + Db::commit(); + return $this->json(); + } + //否则失败 记录失败原因 + Log::info("企业发起付款【分销者红包】失败:" . json_encode($result,JSON_UNESCAPED_UNICODE)); + //默认回滚 + Db::rollback(); + //失败也要写入红包记录 + Redpack::create($redpackData); + return $this->json(5003, "领取失败,发放分享者红包失败"); + } + + Db::commit(); + return $this->json(); + }catch (RepositoryException $e){ + Log::error("优惠券领取失败RepositoryException:".$e->getMessage()); + Db::rollback(); + return $this->json(5001,"领取失败"); + }catch (Exception $e){ + Log::error("优惠券领取失败:".$e->getMessage()); + Db::rollback(); + return $this->json(5001,"领取失败"); + } + + } + + /** + * 核验优惠券 程序----核心操作---- + * */ + public function verification() + { + $accountId = $this->request->user['user_id'] ?? 0; + $lat = input("lat/f",0); + $lng = input("lng/f",0); + $couponId = input("couponId/d",0); + $userTimeStamp = input("userTimeStamp/d",0); + $account = AccountRepository::getInstance()->findById($accountId, [], function ($q) { + return $q->with(['business', 'parent']); + }); + $time = time(); + if(empty($account)){ + return $this->json(6001,"无效的用户"); + } + + if ($lat <= 0 || $lng <= 0) { + return $this->json(4001, "请授权定位"); + } + + $coupon = CouponRepository::getInstance()->findById($couponId,[],function ($q){ + return $q->with(["couponMain","redpack"])->lock(true); + }); + + if(empty($coupon)){ + return $this->json(4001, "优惠券不存在"); + } + if($coupon->consumer_code != $account->user_code ){ + return $this->json(4001, "参数错误"); + } + if($coupon->is_verificated != CouponModel::is_verificated_off){ + return $this->json(4001, "优惠券已验证"); + } + if($coupon->status != CouponMain::status_on){ + return $this->json(4001, "优惠券已停用"); + } + if($coupon->on_shelf != CouponMain::on_shelf_on){ + return $this->json(4001, "优惠券下架"); + } + + + if(!isset($coupon->couponMain) || empty($coupon->couponMain)){ + return $this->json(4001, "商家优惠券信息错误"); + } + if(strtotime($coupon->couponMain->end_time) < $time){ + return $this->json(4001, "优惠券已过期"); + } + //$usingRule = UsingRule::findOne(["coupon_id"=>$coupon->couponMain->id]); + //if(empty($usingRule)){ + // return $this->json(4001, "商家优惠券使用规则信息错误"); + //} + + //一天的开始时间 + //if(strtotime(date("Y-m-d " . $usingRule->day_start_time)) > $time){ + // return $this->json(4001, "请在当天{$usingRule->day_start_time}-{$usingRule->day_start_time}使用"); + //} + //一天的结束时间 + //if(strtotime(date("Y-m-d ".$usingRule->day_end_time)) < $time){ + // return $this->json(4001, "请在当天{$usingRule->day_start_time}-{$usingRule->day_start_time}使用"); + //} + + //使用周期 周一到周天 + //$newW = date("w"); + //if(!in_array($newW,$usingRule->cycle)){ + // return $this->json(4001, "请在".encodeCouponCycle($usingRule->cycle)."使用"); + //} + + + + Config::load('extra/wechat', 'wechat'); + $signDistance = config('wechat.signDistance') ?? 0; + $signTimeStamp = config('wechat.signTimeStamp') ?? 0; + $msectime = msectime();//毫秒时间戳 + + //签到距离 + if($signDistance > 0 ){ + $distance = get_distance($coupon->couponMain->lat,$coupon->couponMain->lng,$lat,$lng); + if($distance > $signDistance){ + if ($distance >= 1000) { + $distanceText = round($distance / 1000, 2) . "千米"; + } else { + $distanceText = $distance . "米"; + } + return $this->json(4001, "您距离商家位置距离超过规定距离{$distanceText}"); + } + } + + //签到时间戳 + if($signTimeStamp > 0 ){ + if(abs($userTimeStamp - $msectime) > $signTimeStamp){ + //.abs($userTimeStamp - $msectime) + return $this->json(4001, "时间戳验证失败"); + } + } + + + $business = BusinessRepository::getInstance()->getModel()->with(["agency"])->where(["code"=>$coupon->couponMain->business_code])->lock(true)->find(); + if(empty($business)){ + return $this->json(4001, "商家不存在"); + } + + if($business->enable != BusinessModel::COMMON_OFF){ + return $this->json(4001, "商家已禁用"); + } + + if($business->balance < $coupon->couponMain->deduction_money){ + return $this->json(4001, "商家余额不足"); + } + + //开始数据操作 + Db::startTrans(); + try { + // 1. 修改优惠券状态 + $coupon->save([ + "is_verificated" => CouponModel::is_verificated_on, + "used_time" => date("Y-m-d H:i:s" ,$time), + "verificate_time" => date("Y-m-d H:i:s" ,$time), + ]); + $coupon->couponMain->save([ + "verification_count" => Db::raw("verification_count + 1"),//已验证数量+1 + "using_count" => Db::raw("using_count - 1"),//进行中数量-1 + ]); + + $deductionMoney = $coupon->couponMain->deduction_money; + + //可分配金额 如果是普通商家 + if($business->model == BusinessModel::model_ordinary) { + $agencyMoney = (($deductionMoney/100) * $coupon->couponMain->commission_agency); + $adminMoney = (($deductionMoney/100) * $coupon->couponMain->commission_admin); + $consumerMoney = (($deductionMoney/100) * $coupon->couponMain->commission_consumer); + + $disAdminMoney = (($deductionMoney/100) * $coupon->couponMain->commission_dis_admin); + $disDistributionMoney = (($deductionMoney/100) * $coupon->couponMain->commission_dis_distribution); + $disDistributedMoney = (($deductionMoney/100) * $coupon->couponMain->commission_dis_distributed); + + + $agencyMoney = round($agencyMoney,2); //四舍五入 精确到分 + $adminMoney = round($adminMoney,2); //四舍五入 精确到分 + $consumerMoney = round($consumerMoney,2); //四舍五入 精确到分 + }else{ + $adminMoney = 0; + $consumerMoney = round($deductionMoney,2) ; + $agencyMoney = 0; //四舍五入 精确到分 + } + + // 2. 写入优惠券流水 + $couponBillData = [ + "coupon_main_id" => $coupon->couponMain->id, + "coupon_id" => $coupon->id, + "user_code" => $account->user_code, + "business_code" => $business->code, + "agency_code" => $business->agency_code, + "commission_agency" => $coupon->couponMain->commission_agency, + "commission_admin" => $coupon->couponMain->commission_admin, + "commission_consumer" => $coupon->couponMain->commission_consumer, + "money" => $coupon->couponMain->money, + "agency_money" => $agencyMoney, + "admin_money" => $adminMoney, + "consumer_money" => $consumerMoney, + "lat" => $lat, + "lng" => $lng, + "create_time" => date("Y-m-d H:i:s" ,$time), + ]; + $couponBill = CouponBill::create($couponBillData); + + // 3. 写入商家扣费记录 + $deductionData = [ + "money" => $deductionMoney, + "user_code" => $account->user_code, + "business_code" => $business->code, + "business_name" => $business->business_name, + "balance" => $business->balance - $deductionMoney, + "reason" => sprintf("[%s]验证优惠券[%s]扣除[%s]",$account->nick_name, $coupon->couponMain->name,$deductionMoney), + "coupon_main_id" => $coupon->couponMain->id, + "coupon_id" => $coupon->id, + "bill_id" => $couponBill->id, + "create_time" => date("Y-m-d H:i:s",$time), + ]; + Deduction::create($deductionData); + + //4. 商家扣钱 + $business->save(["balance"=>Db::raw("balance - " . $deductionMoney)]); + + //5. 渠道商加钱 + if(isset($business->agency) && $business->agency){ + $business->agency->inc("balance",$agencyMoney)->update(); + } + + //6. 用户提现到零钱 写入红包记录 + if($consumerMoney > 0){ + $payment = WechatPay::getInstance(); + + //如果付款过一次了 就查询付款状态 + if(isset($coupon->redpack) && $coupon->redpack){ + $mch_billno = $coupon->redpack->mch_billno; +// $result = $payment->transfer->queryBalanceOrder($coupon->redpack->mch_billno); +// //var_dump($result); +// //企业付款成功 +// if(isset($result["status"]) && $result["status"]=="SUCCESS"){ +// Db::commit(); +// return $this->json( +// 0, +// "优惠券签到使用成功,您获得{$consumerMoney}元红包,已存入您的零钱", +// [ +// "redpack" =>$consumerMoney +// ]); +// } +// Log::info("查询企业付款失败:".json_encode($result,JSON_UNESCAPED_UNICODE)); + }else{ + $mch_billno = createUuid(); + } + + $amount = $consumerMoney * 100; + + $toBalanceData = [ + 'partner_trade_no' => $mch_billno,// 商户订单号，需保持唯一性(只能是字母或者数字，不能包含有符号) + 'openid' => $account->open_id, + 'check_name' => 'NO_CHECK',// NO_CHECK：不校验真实姓名, FORCE_CHECK：强校验真实姓名 + 'amount' => $amount, //单位为分，不小于100 + 'desc' => '验证优惠券签到', + ]; + + // 写入红包 + $redpackData = [ + "coupon_id" =>$coupon->id, + "mch_billno" =>$mch_billno, + "openid" =>$account->open_id, + "user_code" =>$account->user_code, + "money" =>$amount, + "create_time" => date("Y-m-d H:i:s",$time), + "pay_time" => '0000-00-00 00:00:00', + ]; + + + //发起支付 + $result = $payment->transfer->toBalance($toBalanceData); + + //var_dump($result); + + //付款成功才提交！！！！！伪装成功 + if( isset($result['payment_no']) ){ + $redpackData['pay_time'] = date("Y-m-d H:i:s",$time); + Redpack::create($redpackData); + Db::commit(); + return $this->json( + 0, + "优惠券签到使用成功,您获得{$consumerMoney}元红包,已存入您的零钱", + [ + "redpack" =>$consumerMoney, + "user_coupon_id" =>$couponId, + ]); + } + //否则失败 记录失败原因 + Log::info("企业发起付款失败:" . json_encode($result,JSON_UNESCAPED_UNICODE)); + //默认回滚 + Db::rollback(); + //失败也要写入红包记录 + Redpack::create($redpackData); + return $this->json(5003, "验证失败,发放红包失败"); + } + Db::commit(); + return $this->json(); + + }catch (RepositoryException $e){ + Db::rollback(); + return $this->json(5001, "Repository服务器错误"); + }catch (\Exception $e){ + echo $e->getMessage(); + Db::rollback(); + return $this->json(5002, "服务器错误"); + } + + + } + /** + * 发布优惠券 + * */ + public function add() + { + $accountId = $this->request->user['user_id'] ?? 0; + $account = AccountRepository::getInstance()->findById($accountId, [], function ($q) { + return $q->with(['business'=>function($q){ + $q->lock(true); + }, 'parent']); + }); + if(empty($account)){ + return $this->json(6001,"登录失效"); + } + if ($account->type == Account::type_consumer) { + return $this->json(4001, "您不是商家"); + } + + if (!isset($account->business) || empty($account->business)) { + return $this->json(4001, "商家信息错误"); + } + if($account->business->enable != BusinessModel::COMMON_OFF){ + return $this->json(4001, "商家已禁用"); + } + $data = input(); + + Config::load("extra/distribution_proportion","distribution_proportion"); + Config::load("extra/distribution_proportion_user","distribution_proportion_user"); + $distributionProportion = config("distribution_proportion"); + $distributionProportionUser = config("distribution_proportion_user"); + + $totalC = $distributionProportion['agency'] + $distributionProportion['admin'] + $distributionProportion['consumer']; + if ($totalC != 100) { + return $this->json(4002, "系统设置分配比例总和不等于100,不能发布"); + } + + //持有限量 + Config::load("extra/wechat","wechat"); + $hasCouponMax = config("wechat.hasCouponMax")??0; + if ($hasCouponMax > 0) { + $hasCouponCount = CouponRepository::getInstance()->getBusinessOnShelfOnCount($account->business->code); + if ($hasCouponCount > $hasCouponMax) { + return $this->json(4001, "商家持有优惠券不能超过{$hasCouponMax}"); + } + } + + + + //验证通过 不管是商家还是工作人员 都可以发布优惠券 + $couponMain = [ + "name" => $data['name'] ?? '', + "business_code" => $account->business->code, + //"money" => $data['money'] ?? 0, + "type" => $data['type'] ?? 0, + "count" => $data['count'] ?? 0, + "type_name" => $data['type_name'] ?? '', + "start_time" => $data['start_time'] ?? '', + "end_time" => $data['end_time'] ?? '', + "deduction_money" => $data['deduction_money'] ?? '', + "image_url" => $data['image_url'] ?? '', + "intro" => $data['intro'] ?? '', + "content" => $data['content'] ?? '', + "white_list" => $data['white_list'] ?? '', + "status" => CouponMain::status_on, + "on_shelf" => CouponMain::on_shelf_off,//默认下架 后台审核上架 + "on_screen" => CouponMain::on_screen_yes, + "is_distribution" => CouponMain::COMMON_OFF,//默认关闭分销 + + //下面是分配比例 + "commission_agency" => $distributionProportion['agency'], + "commission_admin" => $distributionProportion['admin'], + "commission_consumer" => $distributionProportion['consumer'], + "commission_dis_admin" => $distributionProportionUser['admin'], + "commission_dis_distribution" => $distributionProportionUser['distribution'], + "commission_dis_distributed" => $distributionProportionUser['distributed'], + ]; + + //$usingRule = input("using_rule/a"); + + $validate = new CouponRelease(); + + //普通商家要验证扣除金额 + + if (!$validate->scene($account->business["model"] == BusinessModel::model_ordinary ? "ordinary" : "")->check($couponMain)) { + return $this->json(4001, $validate->getError()); + } + + //$usingRuleValidate = new CouponUsingRule(); + //if (!$usingRuleValidate->check($usingRule)) { + // return $this->json(4001, $usingRuleValidate->getError()); + //} + + //检查类型 + if(CouponTypeModel::checkType($couponMain['type']) !== true){ + return $this->json(4001, '优惠券类型不存在'); + } + $type = CouponRepository::getInstance()->getCouponTypeAll(); + $type = array_column($type->toArray(), null, "id"); + $couponMain['type_name'] = $type[$couponMain['type']]['name']; + + //验证通过 + $couponMain['business_type'] = $account->business['type']; + $couponMain['business_name'] = $account->business['business_name']; + $couponMain['lng'] = $account->business['lng']; + $couponMain['lat'] = $account->business['lat']; + $couponMain['business_circle_id'] = $account->business['business_circle_id']; + $couponMain['create_time'] = date("Y-m-d H:i:s"); + + //保留两位小数 + $couponMain['deduction_money'] = floor($couponMain['deduction_money'] * 100) / 100; + $totalMoney = $couponMain['deduction_money'] * $couponMain['count']; + + //检测消费者部分是否最少0.3元 + $consumerMoney = ($couponMain['commission_consumer']/100) * $couponMain['deduction_money']; + if ($consumerMoney != 0 && $consumerMoney < CouponMain::min_redpack_money) { + return $this->json(4002, "扣除金额最低" . (CouponMain::min_redpack_money * (100 / ($data['commission_consumer']))) . "元"); + } + + //未领取的优惠券 + $NotClaimedMoney = CouponRepository::getInstance()->getBusinessNotClaimedCoupon($account->business["code"]); + if($account->business["model"] == BusinessModel::model_ordinary) { + if ($account->business["balance"] < ($totalMoney + $NotClaimedMoney)) { + return $this->json(4001, '商家余额不足'); + } + } + + Db::startTrans(); + try { + //CouponRepository::getInstance()->releaseCouponMain($couponMain, $totalMoney, $usingRule); + CouponRepository::getInstance()->releaseCouponMain($couponMain); + Db::commit(); + return $this->json(); + } catch (RepositoryException $e) { + Db::rollback(); + return $this->json(5001, "发布失败" . $e->getMessage()); + } catch (\think\Exception $e) { + Db::rollback(); + return $this->json(5002, "发布失败" . $e->getMessage()); + } + } + + /** + * 修改优惠券 + * */ + public function edit() + { + $accountId = $this->request->user['user_id'] ?? 0; + $couponMainId = input("couponMainId/d"); + $account = AccountRepository::getInstance()->findById($accountId, [], function ($q) { + return $q->with(['business'=>function($q){ + $q->lock(true); + }, 'parent']); + }); + if(empty($account)){ + return $this->json(6001,"登录失效"); + } + if ($account->type == Account::type_consumer) { + return $this->json(4001, "您不是商家"); + } + + if (!isset($account->business) || empty($account->business)) { + return $this->json(4001, "商家信息错误"); + } + + $couponMain = CouponMain::findById($couponMainId,[]); + if (empty($couponMain)) { + return $this->json(4001, "优惠券不存在"); + } + //if (!isset($couponMain->usingRule)||empty($couponMain->usingRule)) { + // return $this->json(4001, "优惠券信息错误"); + //} + $data = input(); + + //验证通过 不管是商家还是工作人员 都可以修改优惠券 只能修改指定字段 + $couponMainData = [ + "name" => $data['name'] ?? '', + "type" => $data['type'] ?? 0, + "type_name" => $data['type_name'] ?? '', + "start_time" => $data['start_time'] ?? '', + "end_time" => $data['end_time'] ?? '', + "image_url" => $data['image_url'] ?? '', + "intro" => $data['intro'] ?? '', + "content" => $data['content'] ?? '', + "white_list" => $data['white_list'] ?? '', + "on_screen" => $data['on_screen'] ?? 1, + ]; + + //$usingRule = input("using_rule/a"); + + $validate = new CouponRelease(); + if (!$validate->scene("api_edit")->check($couponMainData)) { + return $this->json(4001, $validate->getError()); + } + + //$usingRuleValidate = new CouponUsingRule(); + //if (!$usingRuleValidate->check($usingRule)) { + // return $this->json(4001, $usingRuleValidate->getError()); + //} + + //检查类型 + if(CouponTypeModel::checkType($couponMainData['type']) !== true){ + return $this->json(4001, '优惠券类型不存在'); + } + $type = CouponRepository::getInstance()->getCouponTypeAll(); + $type = array_column($type->toArray(), null, "id"); + $couponMainData['type_name'] = $type[$data['type']]['name']; + + //验证通过 + Db::startTrans(); + try { + $couponMain->save($couponMainData); + //$couponMain->usingRule->save($usingRule); + CouponRepository::getInstance()->getModel()->where("coupon_id",$couponMain->id)->update(["end_time"=>$couponMainData["end_time"]." 00:00:00"]); + Db::commit(); + return $this->json(); + } catch (RepositoryException $e) { + Db::rollback(); + return $this->json(5001, "修改失败失败" ); + } catch (\think\Exception $e) { + Db::rollback(); + return $this->json(5002, "修改失败500" ); + } + } + + /** + * 商家管理优惠券 + * */ + public function getPageList() + { + $accountId = $this->request->user['user_id'] ?? 0; + $account = AccountRepository::getInstance()->findById($accountId, [], function ($q) { + return $q->with(['business', 'parent']); + }); + if(empty($account)){ + return $this->json(6001,"登录失效"); + } + if ($account->type == Account::type_consumer) { + return $this->json(4001, "您不是商家"); + } + + if (!isset($account->business) || empty($account->business)) { + return $this->json(4001, "商家信息错误"); + } + + $page = $this->request->param('page/d', 1); + $size = $this->request->param('rows/d', 10); + $page = $page < 1 ? 1 : $page; + $size = $size < 1 ? 10 : $size; + $keyword = $this->request->param('key/s',""); + $businessCode = $account->business_code; + + try { + $whereMap = []; + $sortOrder = ['sort' => 'desc']; + $whereMap[] = ["business_code" ,"=", $businessCode ]; + if(!empty($keyword)){ + $whereMap[] = ["name" ,"like", "%{$keyword}%" ]; + } + $res = CouponRepository::getInstance(new CouponMain())->findList($whereMap, [], $page, $size,function ($q){ + return $q->with(["couponType"]); + }, $sortOrder); + $time = time(); + $res['list'] ->each(function ($item) use($time){ + //已使用张数 + $item->usingCount = CouponRepository::getInstance()->getCouponMainUsingCount($item->id); + if($item->on_shelf === 0 && strtotime($item->start_time) <= $time && strtotime($item->end_time) >= $time){ + $item->conduct = true; + }else{ + $item->conduct = false; + } + + }); + + return $this->json(0, 'success', $res); + } catch (RepositoryException | \Exception $e) { + echo $e->getMessage(); + return $this->json(5001, '优惠卷查询失败！'); + } + } + + /** + * 优惠券的领取 使用记录列表 + * */ + public function getShopCouponList() + { + $accountId = $this->request->user['user_id'] ?? 0; + $keyword = input("key/s"); + $account = AccountRepository::getInstance()->findById($accountId, [], function ($q) { + return $q->with(['business', 'parent']); + }); + if(empty($account)){ + return $this->json(6001,"登录失效"); + } + if ($account->type == Account::type_consumer) { + return $this->json(4001, "您不是商家"); + } + + if (!isset($account->business) || empty($account->business)) { + return $this->json(4001, "商家信息错误"); + } + + $couponMainId = input("couponId/d"); + + $couponMain = CouponMain::findById($couponMainId); + + if(empty($couponMain)){ + return $this->json(4001, "优惠券不存在"); + } + if($couponMain->business_code != $account->business->code){ + return $this->json(4001, "优惠券参数信息错误"); + } + + $page = $this->request->param('page/d', 1); + $size = $this->request->param('rows/d', 10); + $type = $this->request->param('type/s', 10); + $page = $page < 1 ? 1 : $page; + $size = $size < 1 ? 10 : $size; + $sortOrder = ["id"=>"desc"]; + $whereMap = [ + ["coupon_id","=",$couponMainId] + ]; + if(!empty($keyword)){ + $whereMap[] = ["consumer_name", "like", "%{$keyword}%"]; + } + switch ($type) { + case 'all': + // 全部持有优惠券 + $sortOrder = [ 'end_time' => 'asc']; + break; + case 'notUsed': + // 未使用（包含已过期） + $whereMap[] = ['is_verificated', '=', self::BOOL_FALSE]; + $sortOrder = ['end_time' => 'asc']; + break; + case 'normal': + // 未使用且未过期 + $whereMap[] = ['is_verificated', '=', self::BOOL_FALSE]; + $whereMap[] = ['end_time', '< TIME', date('Y-m-d H:i:s')]; + break; + case 'used': + // 已使用 + $whereMap[] = ['is_verificated', '=', self::BOOL_TRUE]; + $sortOrder = ['verificate_time' => 'desc']; + break; + } + $field = ["is_verificated","received_time","verificate_time","consumer_code","consumer_name","id"]; + $data = CouponRepository::getInstance()->findList($whereMap,$field,$page,$size,function($q){ + return $q->withjoin(["account"=>function($q){ + $q->field(["nick_name","avatar_url","gender","user_code"]); + }]); + },$sortOrder); + + //所有 + $data["allNum"] = CouponRepository::getInstance()->getModel()->where(["coupon_id"=>$couponMainId])->count(); + //未使用 + $data["unUsedNum"] = CouponRepository::getInstance()->getModel()->where(['is_verificated' => self::BOOL_FALSE,"coupon_id"=>$couponMainId])->count(); + //已使用 + $data["usedNum"] = CouponRepository::getInstance()->getModel()->where(['is_verificated' => self::BOOL_TRUE ,"coupon_id"=>$couponMainId])->count(); + + return $this->json(0,"success",$data); + + + } + + /** + * 获取优惠券详情 + * */ + public function getCouponMainInfo() + { + $couponMainId = input("couponMainId/d"); + $couponMain = CouponMain::findById($couponMainId,[],function ($q){ + return $q->with(["business"=>function($q){ + $q->field("code,business_subtitle"); + }]); + }); + if(empty($couponMain)){ + return $this->json(4001,"优惠券不存在"); + } + + return $this->json(0,"success",$couponMain->toArray()); + } + + /** + * 已使用优惠券 评分 + * */ + public function score() + { + $accountId = $this->request->user['user_id'] ?? 0; + $couponId = input("couponId/d",0); + $score = input("score/d",5); + + if($score > 5|| $score <= 0){ + return $this->json(4001, "参数错误"); + } + $account = AccountRepository::getInstance()->findById($accountId, [], function ($q) { + return $q->with(['business', 'parent']); + }); + + if(empty($account)){ + return $this->json(6001,"无效的用户"); + } + + $coupon = CouponRepository::getInstance()->findById($couponId,[],function ($q){ + return $q->with(["scoreModel"]); + }); + + if($coupon->consumer_code != $account->user_code ){ + return $this->json(4001, "参数错误"); + } + + if(isset($score->scoreModel) && $score->scoreModel){ + return $this->json(4001, "已经评论过了"); + } + try { + $coupon->scoreModel()->save([ + "user_code"=>$account->user_code, + "business_code"=>$coupon->business_code, + "score"=>$score, + "coupon_id"=>$coupon->id, + "create_time"=>date("Y-m-d H:i:s"), + ]); + return $this->json(); + }catch (RepositoryException| \Exception $e){ + return $this->json(4001, "评分失败"); + } + + } +>>>>>>> c532c5731ea707997a8d0718b9df9a8096593d76 } \ No newline at end of file