580 lines
22 KiB
PHP
580 lines
22 KiB
PHP
<?php
|
|
|
|
namespace app\api\logic;
|
|
|
|
use app\api\controller\Shop;
|
|
use app\common\enum\BargainEnum;
|
|
use app\common\model\goods\GoodsItem;
|
|
use app\common\basics\Logic;
|
|
use app\common\server\ConfigServer;
|
|
use app\common\server\UrlServer;
|
|
use think\facade\Db;
|
|
use think\Exception;
|
|
use app\common\model\bargain\Bargain;
|
|
use app\common\model\bargain\BargainItem;
|
|
use app\common\model\bargain\BargainKnife;
|
|
use app\common\model\bargain\BargainLaunch;
|
|
use app\common\model\goods\GoodsSpec;
|
|
use app\common\model\goods\GoodsSpecValue;
|
|
|
|
/**
|
|
* Class BargainLogic
|
|
* @package app\api\logic
|
|
*/
|
|
class BargainLogic extends Logic
|
|
{
|
|
/**
|
|
* @notes 获取砍价成功人数
|
|
* @return int
|
|
* @author suny
|
|
* @date 2021/7/13 6:17 下午
|
|
*/
|
|
public static function bargainNumber()
|
|
{
|
|
|
|
return BargainLaunch::where(['status' => 1])
|
|
->count();
|
|
}
|
|
|
|
|
|
/**
|
|
* @notes 砍价列表
|
|
* @param $page
|
|
* @param $size
|
|
* @return array
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
* @throws \think\db\exception\DbException
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
* @author suny
|
|
* @date 2021/7/13 6:17 下午
|
|
*/
|
|
public static function lists($page, $size)
|
|
{
|
|
|
|
$now = time();
|
|
$where[] = ['B.del', '=', 0];
|
|
$where[] = ['B.status', '=', 1];
|
|
$where[] = ['B.audit_status', '=', 1];
|
|
$where[] = ['activity_start_time', '<', $now];
|
|
$where[] = ['activity_end_time', '>', $now];
|
|
|
|
$bargain_count = Bargain::alias('B')
|
|
->join('Goods G', 'B.goods_id = G.id')
|
|
->where($where)
|
|
->count();
|
|
|
|
$bargain_list = Bargain::alias('B')
|
|
->join('Goods G', 'B.goods_id = G.id')
|
|
->where($where)
|
|
->page($page, $size)
|
|
->order('id desc')
|
|
->field('B.id,B.bargain_min_price as activity_price,G.id as goods_id,G.name,G.image,G.min_price as price')
|
|
->withAttr('image', function ($value, $data) {
|
|
|
|
return UrlServer::getFileUrl($value);
|
|
})
|
|
->select();
|
|
|
|
$more = is_more($bargain_count, $page, $size); //是否有下一页
|
|
|
|
$data = [
|
|
'list' => $bargain_list,
|
|
'page_no' => $page,
|
|
'page_size' => $size,
|
|
'count' => $bargain_count,
|
|
'more' => $more
|
|
];
|
|
return $data;
|
|
}
|
|
|
|
/**
|
|
* @notes 砍价活动详情
|
|
* @param $bargain_id
|
|
* @return array|\think\Model|null
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
* @throws \think\db\exception\DbException
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
* @author suny
|
|
* @date 2021/7/13 6:17 下午
|
|
*/
|
|
public static function detail($bargain_id)
|
|
{
|
|
|
|
$detail = Bargain::alias('B')
|
|
->join('goods G', 'B.goods_id = G.id')
|
|
->where(['B.id' => $bargain_id])
|
|
->field('B.id,B.shop_id,B.bargain_min_price as activity_price,G.id as goods_id,G.name,G.image,G.min_price as price')
|
|
->withAttr('image', function ($value, $data) {
|
|
|
|
return UrlServer::getFileUrl($value);
|
|
})
|
|
->find();
|
|
|
|
$detail['goods_item'] = BargainItem::alias('BI')
|
|
->join('goods_item GI', 'BI.item_id = GI.id')
|
|
->where(['BI.goods_id' => $detail['goods_id']])
|
|
->field('BI.floor_price as activity_price,GI.id,GI.image,GI.price,GI.spec_value_ids,GI.spec_value_str')
|
|
->select();
|
|
|
|
$spec_list = GoodsSpec::where(['goods_id' => $detail['goods_id']])
|
|
->column('*', 'id');
|
|
|
|
$spec_value_list = GoodsSpecValue::where(['goods_id' => $detail['goods_id']])
|
|
->select();
|
|
|
|
foreach ($spec_value_list as $spec_value) {
|
|
if (isset($spec_list[$spec_value['spec_id']])) {
|
|
$spec_list[$spec_value['spec_id']]['spec_value'][] = $spec_value;
|
|
}
|
|
}
|
|
|
|
|
|
foreach ($detail['goods_item'] as $key => $goods_item) {
|
|
|
|
if (empty($goods_item['image'])) {
|
|
$goods_item['image'] = $detail['image'];
|
|
}
|
|
$detail['goods_item'][$key]['image'] = UrlServer::getFileUrl($goods_item['image']);
|
|
}
|
|
$detail['goods_spec'] = array_values($spec_list);
|
|
//前端渲染状态
|
|
$detail['status'] = -1;
|
|
//提示字段
|
|
$detail['bargain_tips'] = '您正在发起砍价';
|
|
$detail['simple_tips'] = '邀请好友帮忙砍价，砍至' . $detail['activity_price'] . '即可发货';
|
|
|
|
return $detail;
|
|
}
|
|
|
|
|
|
/**
|
|
* @notes 发起砍价
|
|
* @param $post_data
|
|
* @param $user_id
|
|
* @return array|false
|
|
* @throws \think\exception\PDOException
|
|
* @author suny
|
|
* @date 2021/7/13 6:17 下午
|
|
*/
|
|
public static function sponsor($post_data, $user_id)
|
|
{
|
|
|
|
Db::startTrans();
|
|
try {
|
|
$shop_id = Bargain::where('id', $post_data['bargain_id'])->value('shop_id');
|
|
//商品规格信息
|
|
$goods_item = GoodsItem::alias('GI')
|
|
->join('goods G', 'G.id = GI.goods_id')
|
|
->where(['GI.id' => $post_data['item_id']])
|
|
->field('G.name,G.image as goods_iamge,GI.id as item_id,GI.image,GI.spec_value_str,GI.price')
|
|
->find();
|
|
|
|
$bargain = Bargain::alias('B')
|
|
->join('bargain_item BI', 'B.id = BI.bargain_id')
|
|
->where(['B.id' => $post_data['bargain_id'], 'BI.item_id' => $post_data['item_id'], 'B.del' => 0])
|
|
->field('B.*,BI.floor_price,BI.item_id,BI.first_knife_price')
|
|
->find();
|
|
$now = time();
|
|
//砍到价格
|
|
$current_price = $goods_item['price'] - $bargain['first_knife_price'];
|
|
|
|
$status = BargainLaunch::conductStatus;
|
|
$payment_limit_time = 0;
|
|
$bargain_end_time = 0;
|
|
//首刀砍掉后小于零，或低于底价
|
|
if ($current_price <= $bargain['floor_price'] || $current_price <= 0) {
|
|
//标记砍价成功
|
|
$status = BargainLaunch::successStatus;
|
|
|
|
//砍价的价格低于低价、重新计算每刀价格
|
|
if ($current_price < $bargain['floor_price']) {
|
|
$current_price = $bargain['floor_price'];
|
|
$bargain['first_knife_price'] = $goods_item['price'] - $current_price;
|
|
}
|
|
//砍价成功后的付款时间（秒）
|
|
$payment_limit_time = ConfigServer::get('bargain', 'payment_limit_time', 0) * 60;
|
|
if ($payment_limit_time > 0) {
|
|
$payment_limit_time = $now + $payment_limit_time;
|
|
}
|
|
$bargain_end_time = $now;
|
|
}
|
|
|
|
|
|
$diff_price = round($current_price - $bargain['floor_price'], 2);
|
|
$bargain_sn = createSn('bargain_launch', 'bargain_sn');
|
|
$bargain_launch = [
|
|
'bargain_id' => $bargain['id'],
|
|
'goods_id' => $bargain['goods_id'],
|
|
'user_id' => $user_id,
|
|
'order_id' => '',
|
|
'goods_snap' => json_encode($goods_item), //规格信息
|
|
'bargain_snap' => json_encode($bargain), //砍价信息
|
|
'help_number' => 1, //助力次数
|
|
'bargain_price' => $bargain['floor_price'], //商品活动低价
|
|
'current_price' => $current_price, //当前砍到的价格
|
|
'launch_start_time' => $now, //砍价发起时间
|
|
'launch_end_time' => $now + $bargain['time_limit'] * 3600,//砍价结束时间
|
|
'bargain_end_time' => $bargain_end_time, //最后的砍价时间
|
|
'payment_limit_time' => $payment_limit_time, //最后的付款时间
|
|
'status' => $status, //当前砍价状态
|
|
'shop_id' => $shop_id, //店铺ID
|
|
'bargain_sn' => $bargain_sn, //砍价订单编号
|
|
];
|
|
//写入发起砍价表
|
|
$bargain_launch_id = BargainLaunch::insertGetId($bargain_launch);
|
|
|
|
$bargain_knife = [
|
|
'bargain_id' => $bargain['id'],
|
|
'launch_id' => $bargain_launch_id,
|
|
'user_id' => $user_id,
|
|
'surplus_price' => $current_price,
|
|
'help_price' => $bargain['first_knife_price'],
|
|
'help_time' => $now
|
|
];
|
|
|
|
//写入砍价记录表
|
|
BargainKnife::insert($bargain_knife);
|
|
|
|
//砍价进度条
|
|
if ($current_price == 0) {
|
|
$progress = round(1, 2);
|
|
} else {
|
|
$progress = round($bargain['floor_price'] / $current_price, 2);
|
|
}
|
|
|
|
Db::commit();
|
|
$data = [
|
|
'id' => $bargain_launch_id,
|
|
'knife_price' => $bargain['first_knife_price'],
|
|
'diff_price' => $diff_price,
|
|
'progress' => $progress
|
|
];
|
|
return $data;
|
|
} catch (Exception $e) {
|
|
Db::rollback();
|
|
self::$error = $e->getMessage();
|
|
return false;
|
|
}
|
|
|
|
}
|
|
|
|
/**
|
|
* @notes 砍价助力
|
|
* @param $id
|
|
* @param $user_id
|
|
* @return array|false
|
|
* @throws \think\exception\PDOException
|
|
* @author suny
|
|
* @date 2021/7/13 6:17 下午
|
|
*/
|
|
public static function knife($id, $user_id)
|
|
{
|
|
|
|
Db::startTrans();
|
|
try {
|
|
$now = time();
|
|
$bargain_launch = new BargainLaunch();
|
|
$bargain_launch = $bargain_launch
|
|
->where(['id' => $id])
|
|
->find();
|
|
|
|
$bargain_snap = $bargain_launch['bargain_snap'];
|
|
//每刀随机金额
|
|
if (1 == $bargain_snap['knife_type']) {
|
|
$knife__price_array = explode(',', $bargain_launch['bargain_snap']['knife_price']);
|
|
$knife_price = round(random_float(array_pop($knife__price_array), array_pop($knife__price_array)), 2);
|
|
|
|
} else { //每刀固定金额
|
|
$knife_price = $bargain_launch['bargain_snap']['knife_price'];
|
|
}
|
|
|
|
//商品的低价
|
|
$low_price = $bargain_launch['bargain_price'];
|
|
//砍价后的金额
|
|
$knife_after_price = $bargain_launch['current_price'] - $knife_price;
|
|
$status = BargainLaunch::conductStatus; //砍价状态
|
|
$payment_limit_time = 0; //砍价成功后的付款时间
|
|
$bargain_end_time = 0; //最后的砍刀时间
|
|
|
|
//如果砍价后低于低价，按当前的价格-低价来得到每刀金额,并标记砍价成功
|
|
if ($knife_after_price <= $low_price) {
|
|
//砍价成功后的付款时间（秒）
|
|
$payment_limit_time = ConfigServer::get('bargain', 'payment_limit_time', 0) * 60;
|
|
|
|
$status = BargainLaunch::successStatus;
|
|
if ($payment_limit_time > 0) {
|
|
$payment_limit_time = $now + $payment_limit_time;
|
|
}
|
|
$bargain_end_time = $now;
|
|
$knife_price = round($bargain_launch['current_price'] - $low_price, 2); //砍价的金额 = 当前砍到的价格 - 低价
|
|
$knife_after_price = $low_price; //砍价后更新为低价
|
|
}
|
|
|
|
//写入砍价助力表
|
|
$knife_data = [
|
|
'bargain_id' => $bargain_snap['id'], //活动id
|
|
'launch_id' => $bargain_launch['id'], //订单id
|
|
'user_id' => $user_id, //用户id
|
|
'surplus_price' => $knife_after_price, //助力后的价格
|
|
'help_price' => $knife_price, //助力的金额
|
|
'help_time' => $now,
|
|
];
|
|
BargainKnife::insert($knife_data);
|
|
|
|
//更新砍价进度
|
|
$bargain_launch->help_number = ['inc', 1]; //助力次数+1
|
|
$bargain_launch->current_price = $knife_after_price; //助力后的价格
|
|
$bargain_launch->status = $status; //砍价状态
|
|
|
|
//砍价成功 限制多少时间内付款
|
|
if ($payment_limit_time > 0) {
|
|
$bargain_launch->payment_limit_time = $payment_limit_time;
|
|
}
|
|
if ($bargain_end_time > 0) {
|
|
$bargain_launch->bargain_end_time = $bargain_end_time;
|
|
}
|
|
|
|
$bargain_launch->save();
|
|
|
|
//进度条、剩余差价
|
|
if ($knife_after_price == 0) {
|
|
$progress = round(1, 2);
|
|
} else {
|
|
$progress = round($bargain_snap['floor_price'] / $knife_after_price, 2);
|
|
}
|
|
$diff_price = round($knife_after_price - $bargain_snap['floor_price'], 2);
|
|
|
|
Db::commit();
|
|
$data = [
|
|
'status' => $status,
|
|
'knife_price' => $knife_price,
|
|
'diff_price' => $diff_price,
|
|
'progress' => $progress
|
|
];
|
|
return $data;
|
|
|
|
|
|
} catch (Exception $e) {
|
|
Db::rollback();
|
|
self::$error = $e->getMessage();
|
|
return false;
|
|
}
|
|
|
|
}
|
|
|
|
/**
|
|
* @notes 砍价订单
|
|
* @param $type
|
|
* @param $user_id
|
|
* @param $page
|
|
* @param $size
|
|
* @return array
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
* @throws \think\db\exception\DbException
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
* @throws \think\exception\DbException
|
|
* @author suny
|
|
* @date 2021/7/13 6:18 下午
|
|
*/
|
|
public static function orderList($type, $user_id, $page, $size)
|
|
{
|
|
|
|
$where[] = ['user_id', '=', $user_id];
|
|
if ('-1' != $type && $type != '') {
|
|
$where[] = ['status', '=', $type];
|
|
}
|
|
$bargain_launch = new BargainLaunch();
|
|
|
|
$order_count = $bargain_launch
|
|
->where($where)
|
|
->count();
|
|
|
|
$order_list = $bargain_launch
|
|
->alias('al')
|
|
->join('shop s', 's.id = al.shop_id')
|
|
->where($where)
|
|
->field('al.* ,s.name as shop_name')
|
|
->page($page, $size)
|
|
->order('al.id desc')
|
|
->append(['item_id', 'btn_tips', 'bargain_tips', 'image', 'goods_image', 'name', 'price', 'spec_value_str', 'status_text', 'create_time'])
|
|
->visible(['id', 'bargain_id', 'goods_id', 'item_id', 'image', 'goods_image', 'name', 'price', 'spec_value_str', 'order_id', 'current_price', 'buy_btn', 'bargain_btn', 'pay_btn', 'status_text', 'create_time', 'shop_name'])
|
|
->select();
|
|
|
|
$more = is_more($order_count, $page, $size); //是否有下一页
|
|
|
|
$data = [
|
|
'list' => $order_list,
|
|
'page_no' => $page,
|
|
'page_size' => $size,
|
|
'count' => $order_count,
|
|
'more' => $more
|
|
];
|
|
|
|
return $data;
|
|
}
|
|
|
|
/**
|
|
* @notes 砍价详情页
|
|
* @param $id
|
|
* @param $user_id
|
|
* @return array
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
* @throws \think\db\exception\DbException
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
* @throws \think\exception\DbException
|
|
* @author suny
|
|
* @date 2021/7/13 6:18 下午
|
|
*/
|
|
public static function bargainDetail($id, $user_id)
|
|
{
|
|
|
|
$bargain_launch = new BargainLaunch();
|
|
$bargain_launch = $bargain_launch
|
|
->where(['id' => $id])
|
|
->with('bargain_knife.user')
|
|
->append(['item_id', 'image', 'name', 'price', 'spec_value_str', 'over_time', 'diff_price', 'activity_price', 'progress', 'knife_list', 'knife_price', 'share_titles', 'share_intros'])
|
|
->find();
|
|
//砍价快照
|
|
$bargain_snap = $bargain_launch['bargain_snap'];
|
|
|
|
$bargain_launch = $bargain_launch->visible(['id', 'bargain_id', 'shop_id', 'user_id', 'goods_id', 'item_id', 'order_id', 'name', 'image', 'price', 'spec_value_str', 'current_price', 'floor_price', 'diff_price', 'progress', 'knife_list', 'status', 'knife_price', 'share_titles', 'share_intros', 'payment_limit_time'])
|
|
->hidden(['bargain_knife'])
|
|
->toArray();
|
|
|
|
$user_info = current($bargain_launch['knife_list']);
|
|
$now = time();
|
|
|
|
//好友点击分享行为按钮
|
|
$sponsor_btn = 0; //我也要砍价按钮
|
|
$knife_btn = 0; //帮忙砍一刀按钮
|
|
//查看自己砍价行为按钮
|
|
$direct_buy_btn = 0; //直接购买按钮
|
|
$buy_btn = 0; //立即购买按钮
|
|
$invite_btn = 0; //邀请好友按钮
|
|
$order_btn = 0; //查看订单按钮
|
|
//提示语，通用
|
|
$bargain_tips = ''; //砍价提示，最上方提示
|
|
$simple_tips = ''; //提示，砍价提示下方提示
|
|
$status_tips = ''; //状态提示
|
|
//分享用户的头像
|
|
$bargain_launch['share_avatar'] = '';
|
|
|
|
//显示按钮：查看自己的砍价、好友点击分享进来
|
|
if ($bargain_launch['user_id'] != $user_id) { //好友点击分享进来
|
|
$bargain_launch['status'] = 5;//标记为好友邀请进来的
|
|
//我也要砍价按钮
|
|
$sponsor_btn = 1;
|
|
$bargain_tips = '来自' . $user_info['nickname'] . '的分享';
|
|
$bargain_launch['share_avatar'] = $user_info['avatar'];
|
|
$simple_tips = '谢谢您的助力，动动手指帮我砍一刀';
|
|
|
|
if ($bargain_launch['over_time'] <= $now || 1 == $bargain_launch['status'] || 2 == $bargain_launch['status']) {
|
|
$status_tips = '砍价已结束，去看看其他商品吧~';
|
|
} else {
|
|
|
|
$bargain_knife = Db::name('bargain_knife')->where(['launch_id' => $bargain_launch['id'], 'user_id' => $user_id])->find();
|
|
|
|
if (empty($bargain_knife)) {
|
|
//帮忙砍一刀按钮
|
|
$knife_btn = 1;
|
|
}
|
|
|
|
}
|
|
|
|
|
|
} else {//自己的砍价
|
|
|
|
$simple_tips = '邀请好友帮砍价，砍至' . $bargain_snap['floor_price'] . '即可发货';
|
|
//砍价进行中
|
|
if (0 == $bargain_launch['status'] && $bargain_launch['over_time'] > $now) {
|
|
//邀请好友按钮
|
|
$invite_btn = 1;
|
|
$bargain_tips = '砍价中';
|
|
if (2 == $bargain_snap['payment_where']) {
|
|
//显示直接购买按钮
|
|
$direct_buy_btn = 1;
|
|
}
|
|
$status_tips = '砍价中';
|
|
}
|
|
|
|
//砍价成功
|
|
if (1 == $bargain_launch['status'] || (2 == $bargain_snap['payment_where'] && $bargain_launch['over_time'] <= $now)) {
|
|
$bargain_tips = '砍价成功';
|
|
$status_tips = '恭喜您，砍价成功';
|
|
//砍价成功，没有超过付款时间,且没有下单的，显示购买按钮
|
|
$buy_btn = 1;
|
|
if ($bargain_launch['order_id'] || ($bargain_launch['payment_limit_time'] && $bargain_launch['payment_limit_time'] < $now)) {
|
|
|
|
$buy_btn = 0;
|
|
if ($bargain_launch['payment_limit_time'] && $bargain_launch['payment_limit_time'] < $now) {
|
|
$status_tips = '已超过下单时间，无法下单';
|
|
}
|
|
}
|
|
|
|
//已下单
|
|
if ($bargain_launch['order_id']) {
|
|
$order_btn = 1;
|
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
//砍价失败
|
|
if (($bargain_launch['over_time'] <= $now && 1 != $bargain_launch['status'] && 2 != $bargain_snap['payment_where']) || 2 == $bargain_launch['status']) {
|
|
$bargain_tips = '砍价失败';
|
|
$status_tips = '非常遗憾，砍价失败';
|
|
}
|
|
|
|
}
|
|
$bargain_launch['sponsor_btn'] = $sponsor_btn;
|
|
$bargain_launch['knife_btn'] = $knife_btn;
|
|
$bargain_launch['direct_buy_btn'] = $direct_buy_btn;
|
|
$bargain_launch['buy_btn'] = $buy_btn;
|
|
$bargain_launch['invite_btn'] = $invite_btn;
|
|
$bargain_launch['order_btn'] = $order_btn;
|
|
$bargain_launch['bargain_tips'] = $bargain_tips;
|
|
$bargain_launch['simple_tips'] = $simple_tips;
|
|
$bargain_launch['status_tips'] = $status_tips;
|
|
|
|
return $bargain_launch;
|
|
|
|
}
|
|
|
|
/**
|
|
* @notes 关闭砍价订单
|
|
* @param $id
|
|
* @return bool
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
* @throws \think\db\exception\DbException
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
* @author suny
|
|
* @date 2021/7/13 6:18 下午
|
|
*/
|
|
public static function closeBargain($id)
|
|
{
|
|
|
|
$bargain_launch = new BargainLaunch();
|
|
$bargain_launch = $bargain_launch
|
|
->where(['id' => $id])
|
|
->find();
|
|
|
|
//标记砍价结束
|
|
if ($bargain_launch['launch_end_time'] < time() && 0 == $bargain_launch['status']) {
|
|
|
|
//任意金额购买标记成功
|
|
if (2 == $bargain_launch['bargain_snap']['payment_where']) {
|
|
$status = 1;
|
|
} else {//砍到低价
|
|
$status = 2;
|
|
if ($bargain_launch['bargain_price'] > $bargain_launch['current_price']) {
|
|
$status = 1;
|
|
}
|
|
}
|
|
$bargain_launch->status = $status;
|
|
$bargain_launch->save();
|
|
}
|
|
|
|
return true;
|
|
}
|
|
} |