1299 lines
52 KiB
PHP
1299 lines
52 KiB
PHP
<?php
|
|
/**
|
|
* ThinkShop商城系统 - 团队十年电商经验汇集巨献!
|
|
* =========================================================
|
|
* Copy right 2019-2029 成都云之牛科技有限公司, 保留所有权利。
|
|
* ----------------------------------------------
|
|
* 官方网址: https://www.cdcloudshop.com
|
|
* =========================================================
|
|
*/
|
|
|
|
namespace addon\bargain\model;
|
|
|
|
use addon\weapp\model\Message as WeappMessage;
|
|
use addon\wechat\model\Message as WechatMessage;
|
|
use app\model\BaseModel;
|
|
use app\model\goods\Goods;
|
|
use app\model\member\Member;
|
|
use app\model\message\Message;
|
|
use app\model\message\Sms;
|
|
use app\model\system\Cron;
|
|
use app\model\order\Order;
|
|
use think\facade\Cache;
|
|
use think\facade\Db;
|
|
use think\facade\Log;
|
|
|
|
/**
|
|
* 砍价活动
|
|
*/
|
|
class Bargain extends BaseModel
|
|
{
|
|
|
|
private $status = [
|
|
0 => '未开始',
|
|
1 => '进行中',
|
|
2 => '已结束',
|
|
3 => '已关闭'
|
|
];
|
|
|
|
/**
|
|
* 获取砍价活动状态
|
|
* @return array
|
|
*/
|
|
public function getBargainStatus()
|
|
{
|
|
return $this->success($this->status);
|
|
}
|
|
|
|
/**
|
|
* 添加砍价
|
|
* @param $common_data
|
|
* @param $goods
|
|
* @param $sku_list
|
|
* @return array
|
|
*/
|
|
public function addBargain($common_data, $goods, $sku_list)
|
|
{
|
|
if (empty($goods[ 'sku_ids' ])) {
|
|
return $this->error('', '该活动至少需要一个商品参与');
|
|
}
|
|
//时间段检测
|
|
$bargain_count = model('promotion_bargain_goods')->getCount([
|
|
[ 'goods_id', 'in', $goods[ 'goods_ids' ] ],
|
|
[ 'status', 'in', '0,1,3,4' ],
|
|
[ 'site_id', '=', $common_data[ 'site_id' ] ],
|
|
[ '', 'exp', Db::raw('not ( (`start_time` > ' . $common_data[ 'end_time' ] . ' and `start_time` > ' . $common_data[ 'start_time' ] . ' ) or (`end_time` < ' . $common_data[ 'start_time' ] . ' and `end_time` < ' . $common_data[ 'end_time' ] . '))') ]//todo 修正 所有的优惠都要一样
|
|
]);
|
|
|
|
if ($bargain_count > 0) {
|
|
return $this->error('', '有商品已设置砍价活动，请不要重复设置');
|
|
}
|
|
|
|
$time = time();
|
|
// 当前时间
|
|
if ($time > $common_data[ 'end_time' ]) {
|
|
return $this->error('', '当前时间不能大于结束时间');
|
|
}
|
|
if ($time > $common_data[ 'start_time' ] && $time < $common_data[ 'end_time' ]) {
|
|
$common_data[ 'status' ] = 1;
|
|
$common_data[ 'status_name' ] = $this->status[ 1 ];
|
|
} else {
|
|
$common_data[ 'status' ] = 0;
|
|
$common_data[ 'status_name' ] = $this->status[ 0 ];
|
|
}
|
|
|
|
model('promotion_bargain')->startTrans();
|
|
try {
|
|
|
|
foreach ($goods[ 'goods_ids' ] as $goods_id) {
|
|
|
|
//添加砍价活动
|
|
$bargain_data = [
|
|
'goods_id' => $goods_id,
|
|
'create_time' => $time
|
|
];
|
|
$bargain_id = model('promotion_bargain')->add(array_merge($bargain_data, $common_data));
|
|
|
|
$bargain_goods_list = [];
|
|
$bargain_stock = 0;
|
|
//添加砍价活动商品
|
|
foreach ($sku_list as $sku) {
|
|
if ($sku[ 'goods_id' ] == $goods_id) {
|
|
|
|
$bargain_stock += $sku[ 'bargain_stock' ];
|
|
|
|
$sku[ 'bargain_id' ] = $bargain_id;
|
|
|
|
$bargain_goods_list[] = array_merge($sku, $common_data);
|
|
}
|
|
}
|
|
|
|
array_multisort(array_column($bargain_goods_list, 'floor_price'), SORT_ASC, $bargain_goods_list);
|
|
model('promotion_bargain')->update(
|
|
[
|
|
'sku_id' => $bargain_goods_list[ 0 ][ 'sku_id' ],
|
|
'floor_price' => $bargain_goods_list[ 0 ][ 'floor_price' ],
|
|
'bargain_stock' => $bargain_stock
|
|
],
|
|
[ [ 'bargain_id', '=', $bargain_id ] ]
|
|
);
|
|
model('promotion_bargain_goods')->addList($bargain_goods_list);
|
|
$cron = new Cron();
|
|
if ($common_data[ 'status' ] == 1) {
|
|
$this->modifyPromotionAddon($bargain_id);
|
|
$cron->addCron(1, 0, "砍价活动关闭", "CloseBargain", $common_data[ 'end_time' ], $bargain_id);
|
|
} else {
|
|
$cron->addCron(1, 0, "砍价活动开启", "OpenBargain", $common_data[ 'start_time' ], $bargain_id);
|
|
$cron->addCron(1, 0, "砍价活动关闭", "CloseBargain", $common_data[ 'end_time' ], $bargain_id);
|
|
}
|
|
}
|
|
|
|
model('promotion_bargain')->commit();
|
|
return $this->success();
|
|
|
|
} catch (\Exception $e) {
|
|
|
|
model('promotion_bargain')->rollback();
|
|
return $this->error('', $e->getMessage());
|
|
}
|
|
|
|
}
|
|
|
|
/**
|
|
* 编辑砍价
|
|
* @param $common_data
|
|
* @param $goods
|
|
* @param $sku_list
|
|
* @return array
|
|
*/
|
|
public function editBargain($common_data, $goods, $sku_list)
|
|
{
|
|
if (empty($goods[ 'sku_ids' ])) {
|
|
return $this->error('', '该活动至少需要一个商品参与');
|
|
}
|
|
$bargain_count = model('promotion_bargain')->getCount(
|
|
[ [ 'bargain_id', '=', $common_data[ 'bargain_id' ] ], [ 'site_id', '=', $common_data[ 'site_id' ] ] ]
|
|
);
|
|
if ($bargain_count == 0) {
|
|
return $this->error('', '数据有误');
|
|
}
|
|
|
|
//时间段检测
|
|
$count = model('promotion_bargain_goods')->getCount([
|
|
[ 'sku_id', 'in', $goods[ 'sku_ids' ] ],
|
|
[ 'status', 'in', '0,1,3,4' ],
|
|
[ 'bargain_id', '<>', $common_data[ 'bargain_id' ] ],
|
|
[ 'site_id', '=', $common_data[ 'site_id' ] ],
|
|
[ '', 'exp', Db::raw('not ( (`start_time` > ' . $common_data[ 'end_time' ] . ' and `start_time` > ' . $common_data[ 'start_time' ] . ' ) or (`end_time` < ' . $common_data[ 'start_time' ] . ' and `end_time` < ' . $common_data[ 'end_time' ] . '))') ]//todo 修正 所有的优惠都要一样
|
|
]);
|
|
if ($count > 0) {
|
|
return $this->error('', '有商品已设置砍价活动，请不要重复设置');
|
|
}
|
|
|
|
$time = time();
|
|
if ($time > $common_data[ 'end_time' ]) {
|
|
return $this->error('', '当前时间不能大于结束时间');
|
|
}
|
|
// 当前时间
|
|
if ($time > $common_data[ 'start_time' ] && $time < $common_data[ 'end_time' ]) {
|
|
$common_data[ 'status' ] = 1;
|
|
$common_data[ 'status_name' ] = $this->status[ 1 ];
|
|
} else {
|
|
$common_data[ 'status' ] = 0;
|
|
$common_data[ 'status_name' ] = $this->status[ 0 ];
|
|
}
|
|
model('promotion_bargain')->startTrans();
|
|
try {
|
|
|
|
$bargain_goods_list = [];
|
|
$bargain_stock = 0;
|
|
//添加砍价活动商品
|
|
foreach ($sku_list as $v) {
|
|
$count = model('promotion_bargain_goods')->getCount([ [ 'sku_id', '=', $v[ 'sku_id' ] ], [ 'bargain_id', '=', $common_data[ 'bargain_id' ] ] ]);
|
|
$is_delete = $v[ 'is_delete' ];
|
|
unset($v[ 'is_delete' ]);
|
|
if ($is_delete == 2) {//是否参与 1参与 2不参与
|
|
if ($count > 0) {
|
|
model('promotion_bargain_goods')->delete([ [ 'sku_id', '=', $v[ 'sku_id' ] ], [ 'bargain_id', '=', $common_data[ 'bargain_id' ] ] ]);
|
|
}
|
|
} else {
|
|
$bargain_stock += $v[ 'bargain_stock' ];
|
|
|
|
$bargain_data = array_merge($v, $common_data);
|
|
if ($count > 0) {
|
|
model('promotion_bargain_goods')->update(
|
|
$bargain_data,
|
|
[ [ 'sku_id', '=', $v[ 'sku_id' ] ], [ 'bargain_id', '=', $common_data[ 'bargain_id' ] ] ]
|
|
);
|
|
} else {
|
|
model('promotion_bargain_goods')->add($bargain_data);
|
|
}
|
|
$bargain_goods_list[] = $bargain_data;
|
|
}
|
|
}
|
|
|
|
array_multisort(array_column($bargain_goods_list, 'floor_price'), SORT_ASC, $bargain_goods_list);
|
|
//修改砍价活动
|
|
model('promotion_bargain')->update(
|
|
array_merge([
|
|
'sku_id' => $bargain_goods_list[ 0 ][ 'sku_id' ],
|
|
'floor_price' => $bargain_goods_list[ 0 ][ 'floor_price' ],
|
|
'bargain_stock' => $bargain_stock,
|
|
'modify_time' => $time
|
|
], $common_data),
|
|
[ [ 'bargain_id', '=', $common_data[ 'bargain_id' ] ] ]
|
|
);
|
|
|
|
$cron = new Cron();
|
|
if ($common_data[ 'status' ] == 1) {
|
|
$this->modifyPromotionAddon($common_data[ 'bargain_id' ]);
|
|
|
|
$cron->deleteCron([ [ 'event', '=', 'OpenBargain' ], [ 'relate_id', '=', $common_data[ 'bargain_id' ] ] ]);
|
|
$cron->deleteCron([ [ 'event', '=', 'CloseBargain' ], [ 'relate_id', '=', $common_data[ 'bargain_id' ] ] ]);
|
|
|
|
$cron->addCron(1, 0, "砍价活动关闭", "CloseBargain", $common_data[ 'end_time' ], $common_data[ 'bargain_id' ]);
|
|
} else {
|
|
$cron->deleteCron([ [ 'event', '=', 'OpenBargain' ], [ 'relate_id', '=', $common_data[ 'bargain_id' ] ] ]);
|
|
$cron->deleteCron([ [ 'event', '=', 'CloseBargain' ], [ 'relate_id', '=', $common_data[ 'bargain_id' ] ] ]);
|
|
|
|
$cron->addCron(1, 0, "砍价活动开启", "OpenBargain", $common_data[ 'start_time' ], $common_data[ 'bargain_id' ]);
|
|
$cron->addCron(1, 0, "砍价活动关闭", "CloseBargain", $common_data[ 'end_time' ], $common_data[ 'bargain_id' ]);
|
|
}
|
|
|
|
// 清除活动分享图片
|
|
( new Poster() )->clearShareImg($common_data[ 'bargain_id' ]);
|
|
|
|
model('promotion_bargain')->commit();
|
|
return $this->success();
|
|
} catch (\Exception $e) {
|
|
|
|
model('promotion_bargain')->rollback();
|
|
return $this->error('', $e->getMessage());
|
|
}
|
|
|
|
}
|
|
|
|
/**
|
|
* 删除砍价活动
|
|
* @param $bargain_id
|
|
* @param $site_id
|
|
* @return array|\multitype
|
|
*/
|
|
public function deleteBargain($bargain_id, $site_id)
|
|
{
|
|
//砍价信息
|
|
$bargain_info = model('promotion_bargain')->getInfo([ [ 'bargain_id', '=', $bargain_id ], [ 'site_id', '=', $site_id ] ], 'status');
|
|
if ($bargain_info) {
|
|
|
|
if ($bargain_info[ 'status' ] != 1) {
|
|
$res = model('promotion_bargain')->delete([ [ 'bargain_id', '=', $bargain_id ], [ 'site_id', '=', $site_id ] ]);
|
|
if ($res) {
|
|
//删除商品
|
|
model('promotion_bargain_goods')->delete([ [ 'bargain_id', '=', $bargain_id ], [ 'site_id', '=', $site_id ] ]);
|
|
//删除砍价记录
|
|
model('promotion_bargain_launch')->delete([ [ 'bargain_id', '=', $bargain_id ], [ 'site_id', '=', $site_id ] ]);
|
|
|
|
$cron = new Cron();
|
|
$cron->deleteCron([ [ 'event', '=', 'OpenBargain' ], [ 'relate_id', '=', $bargain_id ] ]);
|
|
$cron->deleteCron([ [ 'event', '=', 'CloseBargain' ], [ 'relate_id', '=', $bargain_id ] ]);
|
|
}
|
|
return $this->success($res);
|
|
} else {
|
|
return $this->error('', '砍价活动进行中,请先关闭该活动');
|
|
}
|
|
|
|
} else {
|
|
return $this->error('', '砍价活动不存在');
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 关闭砍价活动
|
|
* @param $bargain_id
|
|
* @param $site_id
|
|
* @return array
|
|
*/
|
|
public function finishBargain($bargain_id, $site_id)
|
|
{
|
|
//砍价信息
|
|
$bargain_info = model('promotion_bargain')->getInfo([ [ 'bargain_id', '=', $bargain_id ], [ 'site_id', '=', $site_id ] ], 'status');
|
|
if (!empty($bargain_info)) {
|
|
|
|
if ($bargain_info[ 'status' ] != 3) {
|
|
$res = model('promotion_bargain')->update([ 'status' => 3, 'status_name' => $this->status[ 3 ] ], [ [ 'bargain_id', '=', $bargain_id ], [ 'site_id', '=', $site_id ] ]);
|
|
if ($res) {
|
|
|
|
model('promotion_bargain_goods')->update(
|
|
[ 'status' => 3, 'status_name' => $this->status[ 3 ] ],
|
|
[ [ 'bargain_id', '=', $bargain_id ], [ 'site_id', '=', $site_id ] ]
|
|
);
|
|
|
|
model('promotion_bargain_launch')->update([ 'status' => 2 ], [ [ 'bargain_id', '=', $bargain_id ], [ 'status', '=', 0 ] ]);
|
|
|
|
$cron = new Cron();
|
|
$cron->deleteCron([ [ 'event', '=', 'OpenBargain' ], [ 'relate_id', '=', $bargain_id ] ]);
|
|
$cron->deleteCron([ [ 'event', '=', 'CloseBargain' ], [ 'relate_id', '=', $bargain_id ] ]);
|
|
$this->modifyPromotionAddon($bargain_id, true);
|
|
}
|
|
return $this->success($res);
|
|
} else {
|
|
$this->error('', '该砍价活动已关闭');
|
|
}
|
|
|
|
} else {
|
|
$this->error('', '该砍价活动不存在');
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 获取砍价信息
|
|
* @param array $condition
|
|
* @param string $field
|
|
* @return array
|
|
*/
|
|
public function getBargainInfo($condition = [])
|
|
{
|
|
$field = 'pb.*,g.goods_name,g.goods_image';
|
|
$alias = 'pb';
|
|
$join = [
|
|
[
|
|
'goods g',
|
|
'g.goods_id = pb.goods_id',
|
|
'inner'
|
|
]
|
|
];
|
|
$bargain_info = model("promotion_bargain")->getInfo($condition, $field, $alias, $join);
|
|
if (!empty($bargain_info)) {
|
|
|
|
$goods_list = model('goods_sku')->getList(
|
|
[ [ 'goods_id', '=', $bargain_info[ 'goods_id' ] ] ],
|
|
'goods_id,sku_id,sku_name,price,sku_image,stock'
|
|
);
|
|
foreach ($goods_list as $k => $v) {
|
|
$bargain_goods = model('promotion_bargain_goods')->getInfo(
|
|
[ [ 'sku_id', '=', $v[ 'sku_id' ] ], [ 'bargain_id', '=', $bargain_info[ 'bargain_id' ] ] ],
|
|
'first_bargain_price,bargain_stock,floor_price'
|
|
);
|
|
if (empty($bargain_goods)) {
|
|
$bargain_goods = [
|
|
'first_bargain_price' => 0,
|
|
'bargain_stock' => 0,
|
|
'floor_price' => 0
|
|
];
|
|
}
|
|
$goods_list[ $k ] = array_merge($v, $bargain_goods);
|
|
}
|
|
array_multisort(array_column($goods_list, 'bargain_stock'), SORT_DESC, $goods_list);
|
|
$bargain_info[ 'goods_list' ] = $goods_list;
|
|
}
|
|
return $this->success($bargain_info);
|
|
}
|
|
|
|
/**
|
|
* 获取砍价信息
|
|
* @param array $condition
|
|
* @param string $field
|
|
* @return array
|
|
*/
|
|
public function getBargainJoinGoodsList($condition = [])
|
|
{
|
|
$field = 'pb.*,g.goods_name,g.goods_image';
|
|
$alias = 'pb';
|
|
$join = [
|
|
[
|
|
'goods g',
|
|
'g.goods_id = pb.goods_id',
|
|
'inner'
|
|
]
|
|
];
|
|
$bargain_info = model("promotion_bargain")->getInfo($condition, $field, $alias, $join);
|
|
if (!empty($bargain_info)) {
|
|
|
|
$goods_list = model('promotion_bargain_goods')->getList(
|
|
[ [ 'pbg.bargain_id', '=', $bargain_info[ 'bargain_id' ] ] ],
|
|
'pbg.first_bargain_price,pbg.bargain_stock,pbg.floor_price,sku.goods_id,sku.sku_id,sku.sku_name,sku.price,sku.sku_image,sku.stock',
|
|
'', 'pbg', [ [ 'goods_sku sku', 'sku.sku_id = pbg.sku_id', 'inner' ] ]
|
|
);
|
|
|
|
$bargain_info[ 'goods_list' ] = $goods_list;
|
|
}
|
|
return $this->success($bargain_info);
|
|
}
|
|
|
|
/**
|
|
* 获取砍价商品信息
|
|
* @param array $condition
|
|
* @param string $field
|
|
* @return array
|
|
*/
|
|
public function getBargainGoodsDetail($condition = [], $field = '')
|
|
{
|
|
if (empty($field)) $field = 'pb.join_num,pb.browse_num,pb.share_num,pbg.id,pbg.bargain_id,pbg.goods_id,pbg.sku_id,pbg.floor_price,pbg.bargain_stock,pbg.bargain_name,pbg.start_time,pbg.end_time,pbg.buy_type,sku.site_id,sku.sku_name,sku.sku_spec_format,sku.price,sku.promotion_type,sku.stock,sku.click_num,pb.sale_num,sku.collect_num,sku.sku_image,sku.sku_images,sku.goods_content,sku.goods_state,sku.is_virtual,sku.is_free_shipping,sku.goods_spec_format,sku.goods_attr_format,sku.introduction,sku.unit,sku.video_url,g.evaluate,sku.goods_service_ids, g.goods_image,g.goods_stock,g.goods_name,sku.qr_id,g.stock_show,g.sale_show,pb.status as bargain_status,pb.is_own';
|
|
$join = [
|
|
[ 'goods_sku sku', 'pbg.sku_id = sku.sku_id', 'inner' ],
|
|
[ 'goods g', 'g.goods_id = sku.goods_id', 'inner' ],
|
|
[ 'promotion_bargain pb', 'pb.bargain_id = pbg.bargain_id', 'inner' ],
|
|
];
|
|
$bargain_goods_info = model('promotion_bargain_goods')->getInfo($condition, $field, 'pbg', $join);
|
|
return $this->success($bargain_goods_info);
|
|
}
|
|
|
|
/**
|
|
* 获取砍价商品信息
|
|
* @param array $condition
|
|
* @param string $field
|
|
* @return array
|
|
*/
|
|
public function getBargainGoodsSkuList($condition = [])
|
|
{
|
|
$field = 'pb.join_num,pb.browse_num,pb.share_num,pbg.id,pbg.bargain_id,pbg.goods_id,pbg.sku_id,pbg.floor_price
|
|
,pbg.bargain_stock,pbg.bargain_name,pbg.start_time,pbg.end_time,pbg.buy_type,sku.sku_name
|
|
,sku.sku_spec_format,sku.price,sku.stock,sku.sku_image
|
|
,sku.sku_images,g.goods_spec_format,g.goods_image,pb.status as bargain_status,pb.is_own';
|
|
$join = [
|
|
[ 'goods_sku sku', 'pbg.sku_id = sku.sku_id', 'inner' ],
|
|
[ 'goods g', 'g.goods_id = sku.goods_id', 'inner' ],
|
|
[ 'promotion_bargain pb', 'pb.bargain_id = pbg.bargain_id', 'inner' ],
|
|
];
|
|
$bargain_goods_info = model('promotion_bargain_goods')->getList($condition, $field, 'pbg.id asc', 'pbg', $join);
|
|
return $this->success($bargain_goods_info);
|
|
}
|
|
|
|
/**
|
|
* 获取砍价列表
|
|
* @param array $condition
|
|
* @param string $field
|
|
* @param string $order
|
|
* @param null $limit
|
|
* @return array
|
|
*/
|
|
public function getBargainList($condition = [], $field = '*', $order = '', $limit = null)
|
|
{
|
|
$alias = 'pb';
|
|
|
|
if (empty($field)) {
|
|
$field = 'pb.*,g.goods_name,g.goods_image,g.price,g.recommend_way,sku.sku_id,sku.price,sku.sku_name,sku.sku_image,sku.stock as goods_stock,g.label_name,g.goods_class_name,g.stock_show,g.sale_show';
|
|
}
|
|
|
|
$join = [
|
|
[ 'goods g', 'g.goods_id = pb.goods_id', 'inner' ],
|
|
[ 'goods_sku sku', 'g.sku_id = sku.sku_id', 'inner' ],
|
|
];
|
|
$list = model('promotion_bargain')->getList($condition, $field, $order, $alias, $join, '', $limit);
|
|
return $this->success($list);
|
|
}
|
|
|
|
/**
|
|
* 获取砍价分页列表
|
|
* @param array $condition
|
|
* @param int $page
|
|
* @param int $page_size
|
|
* @param string $order
|
|
* @return array
|
|
*/
|
|
public function getBargainPageList($condition = [], $page = 1, $page_size = PAGE_LIST_ROWS, $order = 'pb.bargain_id desc', $field = '')
|
|
{
|
|
$alias = 'pb';
|
|
|
|
if (empty($field)) {
|
|
$field = 'pb.*,g.goods_name,g.goods_image,g.price,g.recommend_way,sku.sku_id,sku.price,sku.sku_name,sku.sku_image,sku.stock as goods_stock,g.label_name,g.goods_class_name,g.stock_show,g.sale_show';
|
|
}
|
|
|
|
$join = [
|
|
[ 'goods g', 'g.goods_id = pb.goods_id', 'inner' ],
|
|
[ 'goods_sku sku', 'g.sku_id = sku.sku_id', 'inner' ],
|
|
];
|
|
$list = model('promotion_bargain')->pageList($condition, $field, $order, $page, $page_size, $alias, $join);
|
|
return $this->success($list);
|
|
}
|
|
|
|
/**
|
|
* 获取砍价商品列表
|
|
* @param $bargain_id
|
|
* @param $site_id
|
|
* @return array
|
|
*/
|
|
public function getBargainGoodsList($bargain_id, $site_id)
|
|
{
|
|
$field = 'pbg.*,sku.sku_name,sku.price,sku.sku_image,sku.stock';
|
|
$alias = 'pbg';
|
|
$join = [
|
|
[
|
|
'goods g',
|
|
'g.goods_id = pbg.goods_id',
|
|
'inner'
|
|
],
|
|
[
|
|
'goods_sku sku',
|
|
'sku.sku_id = pbg.sku_id',
|
|
'inner'
|
|
]
|
|
];
|
|
$condition = [
|
|
[ 'pbg.bargain_id', '=', $bargain_id ], [ 'pbg.site_id', '=', $site_id ],
|
|
[ 'g.is_delete', '=', 0 ], [ 'g.goods_state', '=', 1 ]
|
|
];
|
|
|
|
$list = model('promotion_bargain_goods')->getList($condition, $field, '', $alias, $join);
|
|
return $this->success($list);
|
|
}
|
|
|
|
/**
|
|
* 获取砍价商品分页列表
|
|
* @param array $condition
|
|
* @param bool $field
|
|
* @param string $order
|
|
* @param int $page
|
|
* @param int $list_rows
|
|
* @param string $alias
|
|
* @param array $join
|
|
* @return array
|
|
*/
|
|
public function getBargainGoodsPageList($condition = [], $field = true, $order = '', $page = 1, $list_rows = PAGE_LIST_ROWS, $alias = 'a', $join = [])
|
|
{
|
|
$list = model('promotion_bargain_goods')->pageList($condition, $field, $order, $page, $list_rows, $alias, $join);
|
|
return $this->success($list);
|
|
}
|
|
|
|
/**
|
|
* 开启砍价活动
|
|
* @param $bargain_id
|
|
* @return array
|
|
*/
|
|
public function cronOpenBargain($bargain_id)
|
|
{
|
|
$bargain_info = model('promotion_bargain')->getInfo([ [ 'bargain_id', '=', $bargain_id ] ], 'status');
|
|
if (!empty($bargain_info)) {
|
|
|
|
if ($bargain_info[ 'status' ] == 0) {
|
|
$res = model('promotion_bargain')->update([ 'status' => 1, 'status_name' => $this->status[ 1 ] ], [ [ 'bargain_id', '=', $bargain_id ] ]);
|
|
if ($res) {
|
|
model('promotion_bargain_goods')->update(
|
|
[ 'status' => 1, 'status_name' => $this->status[ 1 ] ],
|
|
[ [ 'bargain_id', '=', $bargain_id ] ]
|
|
);
|
|
|
|
$this->modifyPromotionAddon($bargain_id);
|
|
}
|
|
return $this->success($res);
|
|
} else {
|
|
return $this->error("", "砍价活动已开启或者关闭");
|
|
}
|
|
|
|
} else {
|
|
return $this->error("", "砍价活动不存在");
|
|
}
|
|
|
|
}
|
|
|
|
/**
|
|
* 关闭砍价活动
|
|
* @param $bargain_id
|
|
* @return array|\multitype
|
|
*/
|
|
public function cronCloseBargain($bargain_id)
|
|
{
|
|
$bargain_info = model('promotion_bargain')->getInfo([ [ 'bargain_id', '=', $bargain_id ] ], 'status');
|
|
if (!empty($bargain_info)) {
|
|
|
|
if ($bargain_info[ 'status' ] != 2) {
|
|
$res = model('promotion_bargain')->update([ 'status' => 2, 'status_name' => $this->status[ 2 ] ], [ [ 'bargain_id', '=', $bargain_id ] ]);
|
|
if ($res) {
|
|
model('promotion_bargain_goods')->update(
|
|
[ 'status' => 2, 'status_name' => $this->status[ 2 ] ],
|
|
[ [ 'bargain_id', '=', $bargain_id ] ]
|
|
);
|
|
$data = [ 'status' => 2 ];
|
|
model('promotion_bargain_launch')->update($data, [ [ 'bargain_id', '=', $bargain_id ], [ 'status', '=', 0 ] ]);
|
|
$this->modifyPromotionAddon($bargain_id, true);
|
|
}
|
|
return $this->success($res);
|
|
} else {
|
|
return $this->error("", "该活动已结束");
|
|
}
|
|
} else {
|
|
return $this->error("", "砍价活动不存在");
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 获取砍价发起信息
|
|
* @param array $condition
|
|
* @param string $field
|
|
*/
|
|
public function getBargainLaunchDetail($condition = [], $field = '*', $alias = '', $join = '')
|
|
{
|
|
$data = model('promotion_bargain_launch')->getInfo($condition, $field, $alias, $join);
|
|
if (!empty($data)) {
|
|
return $this->success($data);
|
|
} else {
|
|
return $this->error();
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 获取砍价发起分页列表
|
|
* @param array $condition
|
|
* @param bool $field
|
|
* @param string $order
|
|
* @param int $page
|
|
* @param int $list_rows
|
|
* @param string $alias
|
|
* @param array $join
|
|
* @return array
|
|
*/
|
|
public function getBargainLaunchPageList($condition = [], $field = true, $order = '', $page = 1, $list_rows = PAGE_LIST_ROWS, $alias = 'a', $join = [])
|
|
{
|
|
$data = model('promotion_bargain_launch')->pageList($condition, $field, $order, $page, $list_rows, $alias, $join);
|
|
if (!empty($data[ 'list' ])) {
|
|
foreach ($data[ 'list' ] as $k => $item) {
|
|
$record_data = model('promotion_bargain_record')->pageList([ [ 'launch_id', '=', $item[ 'launch_id' ] ] ], 'headimg', 'id asc', 1, 6);
|
|
$data[ 'list' ][ $k ][ 'bargain_record' ] = $record_data[ 'list' ];
|
|
}
|
|
}
|
|
return $this->success($data);
|
|
}
|
|
|
|
/**
|
|
* 获取砍价发起列表
|
|
* @param array $condition
|
|
* @param bool $field
|
|
* @param string $order
|
|
* @param string $alias
|
|
* @param array $join
|
|
* @param string $group
|
|
* @param null $limit
|
|
* @return mixed
|
|
*/
|
|
public function getBargainLaunchList($condition = [], $field = true, $order = '', $alias = 'a', $join = [], $group = '', $limit = null)
|
|
{
|
|
$list = model('promotion_bargain_launch')->getList($condition, $field, $order, $alias, $join, $group, $limit);
|
|
return $list;
|
|
}
|
|
|
|
/**
|
|
* 查询数据
|
|
* @param array $condition
|
|
*/
|
|
public function getBargainLaunchCount($condition = [])
|
|
{
|
|
$count = model('promotion_bargain_launch')->getCount($condition, 'launch_id');
|
|
return $this->success($count);
|
|
}
|
|
|
|
/**
|
|
* 获取砍价记录
|
|
* @param array $condition
|
|
* @param bool $field
|
|
* @param string $order
|
|
* @param int $page
|
|
* @param int $list_rows
|
|
* @param string $alias
|
|
* @param array $join
|
|
* @return array
|
|
*/
|
|
public function getBargainRecordPageList($condition = [], $field = true, $order = '', $page = 1, $list_rows = PAGE_LIST_ROWS, $alias = 'a', $join = [])
|
|
{
|
|
$data = model('promotion_bargain_record')->pageList($condition, $field, $order, $page, $list_rows, $alias, $join);
|
|
return $this->success($data);
|
|
}
|
|
|
|
|
|
/**
|
|
* 获取砍价记录信息
|
|
* @param array $condition
|
|
* @param string $field
|
|
*/
|
|
public function getBargainRecordInfo($condition = [], $field = '*')
|
|
{
|
|
$data = model('promotion_bargain_record')->getInfo($condition, $field);
|
|
return $this->success($data);
|
|
}
|
|
|
|
|
|
/**
|
|
* 发起砍价
|
|
* @param $id
|
|
* @param $member_id
|
|
*/
|
|
public function launch($id, $member_id, $site_id, $store_id)
|
|
{
|
|
$condition = [
|
|
[ 'pbg.id', '=', $id ],
|
|
[ 'pbg.site_id', '=', $site_id ],
|
|
[ 'pbg.status', '=', 1 ],
|
|
[ 'g.goods_state', '=', 1 ],
|
|
[ 'g.is_delete', '=', 0 ]
|
|
];
|
|
|
|
$field = 'pbg.*, sku.sku_image,sku.sku_name,sku.price,sku.stock';
|
|
$join = [
|
|
[ 'goods_sku sku', 'pbg.sku_id = sku.sku_id', 'inner' ],
|
|
[ 'goods g', 'g.goods_id = pbg.goods_id', 'inner' ]
|
|
];
|
|
$bargain_info = model('promotion_bargain_goods')->getInfo($condition, $field, 'pbg', $join);
|
|
|
|
if (empty($bargain_info)) return $this->error('', '砍价活动已结束');
|
|
|
|
if ($bargain_info[ 'bargain_stock' ] <= 0) return $this->error('', '库存不足');
|
|
if ($bargain_info[ 'stock' ] <= 0) return $this->error('', '库存不足');
|
|
|
|
$launch_info = model('promotion_bargain_launch')->getInfo([ [ 'bargain_id', '=', $bargain_info[ 'bargain_id' ] ], [ 'member_id', '=', $member_id ] ]);
|
|
if ($launch_info && empty($launch_info[ 'status' ])) return $this->error('', '该商品正在砍价中');
|
|
|
|
if ($launch_info && $launch_info[ 'status' ] == 1) return $this->error('', '该商品已砍价成功，不能再次发起');
|
|
|
|
$launch_info = model('promotion_bargain_launch')->getInfo([ [ 'bargain_id', '=', $bargain_info[ 'bargain_id' ] ], [ 'member_id', '=', $member_id ], [ 'order_id', '>', 0 ] ]);
|
|
|
|
if ($launch_info && !empty($launch_info[ 'order_id' ])) return $this->error('', '您已发起过砍价，不能再次发起');
|
|
|
|
$member_info = model('member')->getInfo([ [ 'site_id', '=', $site_id ], [ 'member_id', '=', $member_id ] ], 'nickname,headimg');
|
|
if (empty($member_info)) return $this->error('', '未获取到会员信息');
|
|
|
|
try {
|
|
$data = [
|
|
'bargain_id' => $bargain_info[ 'bargain_id' ],
|
|
'sku_id' => $bargain_info[ 'sku_id' ],
|
|
'goods_id' => $bargain_info[ 'goods_id' ],
|
|
'site_id' => $bargain_info[ 'site_id' ],
|
|
'sku_name' => $bargain_info[ 'sku_name' ],
|
|
'sku_image' => $bargain_info[ 'sku_image' ],
|
|
'price' => $bargain_info[ 'price' ],
|
|
'floor_price' => $bargain_info[ 'floor_price' ],
|
|
'buy_type' => $bargain_info[ 'buy_type' ],
|
|
'bargain_type' => $bargain_info[ 'bargain_type' ],
|
|
'need_num' => $bargain_info[ 'bargain_num' ],
|
|
'start_time' => time(),
|
|
'end_time' => ( time() + ( $bargain_info[ 'bargain_time' ] * 3600 ) ),
|
|
'member_id' => $member_id,
|
|
'nickname' => $member_info[ 'nickname' ],
|
|
'headimg' => $member_info[ 'headimg' ],
|
|
'is_fenxiao' => $bargain_info[ 'is_fenxiao' ],
|
|
'first_bargain_price' => $bargain_info[ 'first_bargain_price' ],
|
|
'curr_price' => $bargain_info[ 'price' ],
|
|
'is_own' => $bargain_info[ 'is_own' ],
|
|
'is_differ_new_user' => $bargain_info[ 'is_differ_new_user' ],
|
|
'distinguish' => $bargain_info[ 'distinguish' ],
|
|
'new_low' => $bargain_info[ 'new_low' ],
|
|
'aged_tall' => $bargain_info[ 'aged_tall' ],
|
|
'aged_fixation' => $bargain_info[ 'aged_fixation' ],
|
|
'store_id' => $store_id
|
|
];
|
|
|
|
$launch_id = model('promotion_bargain_launch')->add($data);
|
|
|
|
if ($launch_id) {
|
|
//修改砍价商品信息
|
|
// model('promotion_bargain_goods')->update(
|
|
// [
|
|
// 'bargain_stock' => $bargain_info[ 'bargain_stock' ] - 1,
|
|
// 'join_num' => $bargain_info[ 'join_num' ] + 1,
|
|
// ]
|
|
// , [ [ 'id', '=', $id ] ]
|
|
// );
|
|
//增加参与人数
|
|
model('promotion_bargain')->setInc([ [ 'bargain_id', '=', $bargain_info[ 'bargain_id' ] ] ], 'join_num');
|
|
|
|
if ($bargain_info[ 'is_own' ]) {
|
|
$this->bargain($launch_id, $member_id, $site_id);
|
|
}
|
|
$cron = new Cron();
|
|
$cron->addCron(1, 0, '砍价发起自动关闭', 'BargainLaunchClose', $data[ 'end_time' ], $launch_id);
|
|
return $this->success($launch_id);
|
|
} else {
|
|
return $this->error();
|
|
}
|
|
} catch (\Exception $e) {
|
|
return $this->error($e->getMessage());
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 砍价
|
|
* @param $launch_id
|
|
* @param $member_id
|
|
* @param $site_id
|
|
*/
|
|
public function bargain($launch_id, $member_id, $site_id)
|
|
{
|
|
model('promotion_bargain_launch')->startTrans();
|
|
try {
|
|
$launch_info = Db::name('promotion_bargain_launch')->where([ [ 'launch_id', '=', $launch_id ], [ 'site_id', '=', $site_id ] ])->lock(true)->find();
|
|
|
|
if (empty($launch_info)) {
|
|
model('promotion_bargain_launch')->rollback();
|
|
return $this->error('', '未获取到砍价信息');
|
|
}
|
|
if ($launch_info[ 'status' ] != 0) {
|
|
model('promotion_bargain_launch')->rollback();
|
|
return $this->error('', '砍价已结束');
|
|
}
|
|
if ($launch_info[ 'is_own' ] == 0 && $launch_info[ 'member_id' ] == $member_id) {
|
|
model('promotion_bargain_launch')->rollback();
|
|
return $this->error('', '不支持给自己砍价');
|
|
}
|
|
$member_bargain_count = model('promotion_bargain_record')->getCount([
|
|
[ 'bl.bargain_id', '=', $launch_info[ 'bargain_id' ] ],
|
|
[ 'br.member_id', '=', $member_id ],
|
|
], 'br.id', 'br', [
|
|
[ 'promotion_bargain_launch bl', 'bl.launch_id = br.launch_id', 'left' ]
|
|
]);
|
|
|
|
$bargain_info = model('promotion_bargain')->getInfo([ [ 'bargain_id', '=', $launch_info[ 'bargain_id' ] ] ], 'help_bargain_num,bargain_max_num');
|
|
|
|
if ($bargain_info && !empty($bargain_info[ 'help_bargain_num' ]) && $member_bargain_count >= $bargain_info[ 'help_bargain_num' ]) {
|
|
return $this->error('', '您的帮砍次数已达上限');
|
|
}
|
|
$launch_info = array_merge($launch_info, $bargain_info);
|
|
//判断商品库存
|
|
$goods_model = new Goods();
|
|
|
|
$goods_sku_stock = $goods_model->getGoodsSkuInfo([ [ 'sku_id', '=', $launch_info[ 'sku_id' ] ] ], 'stock');
|
|
$stock = $goods_sku_stock[ 'data' ][ 'stock' ];
|
|
|
|
if ($stock <= 0) {
|
|
model('promotion_bargain_launch')->rollback();
|
|
return $this->error('', '库存不足');
|
|
}
|
|
|
|
$member_info = model('member')->getInfo([ [ 'site_id', '=', $site_id ], [ 'member_id', '=', $member_id ] ], 'nickname,headimg');
|
|
if (empty($member_info)) {
|
|
model('promotion_bargain_launch')->rollback();
|
|
return $this->error('', '未获取到会员信息');
|
|
}
|
|
|
|
//区分新老用户
|
|
$start_time = time();
|
|
$end_time = date('Y-m-d H:i:s', strtotime('-' . $launch_info[ 'distinguish' ] . ' day'));
|
|
$member_info_data = model('member')->getInfo([ [ 'site_id', '=', $launch_info[ 'site_id' ] ], [ 'member_id', '=', $member_id ], [ 'reg_time', 'between', [ date_to_time($end_time), $start_time ] ] ], 'member_id');
|
|
$is_first = model('promotion_bargain_record')->getCount([ [ 'launch_id', '=', $launch_id ] ], 'id');
|
|
$is_first_member = model('promotion_bargain_record')->getCount([ [ 'member_id', '=', $member_id ] ], 'id');
|
|
if (!$is_first) {
|
|
// 如果是首刀
|
|
$bargain_money = $launch_info[ 'first_bargain_price' ] > 0 ? $launch_info[ 'first_bargain_price' ] : $this->bargainMoneyCalculate($launch_info, $member_info_data, $is_first_member);
|
|
} else {
|
|
$is_exist = model('promotion_bargain_record')->getCount([ [ 'launch_id', '=', $launch_id ], [ 'member_id', '=', $member_id ] ], 'id');
|
|
if ($is_exist) {
|
|
model('promotion_bargain_launch')->rollback();
|
|
return $this->error('', '您已帮好友砍过价了！');
|
|
}
|
|
$bargain_money = $this->bargainMoneyCalculate($launch_info, $member_info_data, $is_first_member);
|
|
}
|
|
|
|
if (( $launch_info[ 'curr_price' ] - $bargain_money ) < $launch_info[ 'floor_price' ]) {
|
|
$bargain_money = $launch_info[ 'curr_price' ] - $launch_info[ 'floor_price' ];
|
|
}
|
|
|
|
if ($bargain_money <= 0) {
|
|
model('promotion_bargain_launch')->rollback();
|
|
return $this->error();
|
|
}
|
|
$data = [
|
|
'launch_id' => $launch_id,
|
|
'member_id' => $member_id,
|
|
'nickname' => $member_info[ 'nickname' ],
|
|
'headimg' => $member_info[ 'headimg' ],
|
|
'money' => $bargain_money,
|
|
'bargain_time' => time()
|
|
];
|
|
|
|
model('promotion_bargain_record')->add($data);
|
|
|
|
// 砍价人数自增
|
|
model('promotion_bargain_launch')->setInc([ [ 'launch_id', '=', $launch_id ] ], 'curr_num');
|
|
|
|
// 当前砍价金额自减
|
|
model('promotion_bargain_launch')->setDec([ [ 'launch_id', '=', $launch_id ] ], 'curr_price', $bargain_money);
|
|
|
|
// 砍价状态
|
|
$status = 0;
|
|
|
|
if (( (float) $launch_info[ 'curr_price' ] - (float) $bargain_money ) <= ( (float) $launch_info[ 'floor_price' ] )) {
|
|
model('promotion_bargain_launch')->update([ 'status' => 1, 'end_time' => time() ], [ [ 'launch_id', '=', $launch_id ] ]);
|
|
$status = 1;
|
|
|
|
$message_model = new Message();
|
|
// 发送消息
|
|
$param = [ 'keywords' => 'BARGAIN_COMPLETE', 'launch_id' => $launch_id, 'site_id' => $launch_info[ 'site_id' ] ];
|
|
$message_model->sendMessage($param);
|
|
}
|
|
|
|
model('promotion_bargain_launch')->commit();
|
|
return $this->success([ 'bargain_money' => sprintf("%.2f", $bargain_money), 'status' => $status ]);
|
|
} catch (\Exception $e) {
|
|
model('promotion_bargain_launch')->rollback();
|
|
return $this->error('', $e->getMessage());
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 砍价金额计算
|
|
* @param $data
|
|
*/
|
|
private function bargainMoneyCalculate($data, $member_info, $is_first_member)
|
|
{
|
|
$bargain_money = 0;
|
|
$bargain_num = $data[ 'first_bargain_price' ] > 0 ? $data[ 'need_num' ] - 1 : $data[ 'need_num' ];
|
|
$bargain_max_num = $data[ 'bargain_max_num' ] ? ( $data[ 'first_bargain_price' ] > 0 ? $data[ 'bargain_max_num' ] - 1 : $data[ 'bargain_max_num' ] ) : 0;
|
|
|
|
//平均砍价金额
|
|
$average_bargain_money = ( $data[ 'price' ] - $data[ 'floor_price' ] - $data[ 'first_bargain_price' ] ) / $bargain_num;
|
|
$need_money = $data[ 'curr_price' ] - $data[ 'floor_price' ]; // 剩余需砍金额
|
|
if ($need_money <= 0.01) return 0.01;
|
|
$rate = 0.5;
|
|
if (!empty($bargain_max_num)) $rate = ( $bargain_max_num - $bargain_num ) / $bargain_max_num;
|
|
|
|
|
|
if (!$data[ 'buy_type' ] && $data[ 'bargain_type' ] == 1) {
|
|
if ($bargain_max_num && ( $data[ 'curr_num' ] + 1 ) >= $data[ 'bargain_max_num' ]) return $need_money;
|
|
//帮砍随机金额,任意金额可购买
|
|
$bargain_money = round(mt_rand(( $average_bargain_money * 100 ) - ( $average_bargain_money * $rate * 100 ), $average_bargain_money * 100), 2);
|
|
|
|
$bargain_money /= 100;
|
|
} else if ($data[ 'buy_type' ] && $data[ 'bargain_type' ] == 1) {
|
|
//随机绑砍，指定金额购买
|
|
$need_num = $data[ 'need_num' ] - $data[ 'curr_num' ]; // 剩余需帮砍人数
|
|
if ($need_num > 0) {
|
|
if ($data[ 'is_differ_new_user' ] && $member_info && empty($is_first_member)) {
|
|
$bargain_money = mt_rand($data[ 'new_low' ], ( round(( $need_money / $need_num ), 2) * 100 ));
|
|
} else {
|
|
if ($data[ 'is_differ_new_user' ]) {
|
|
$bargain_money = mt_rand(1, ( $data[ 'aged_tall' ] * 100 ));
|
|
} else {
|
|
$bargain_money = mt_rand(1, ( round(( $need_money / $need_num ), 2) * 100 ));
|
|
}
|
|
}
|
|
} else {
|
|
|
|
if ($bargain_max_num && ( $data[ 'curr_num' ] + 1 ) >= $data[ 'bargain_max_num' ]) {
|
|
$bargain_money = $need_money * 100;
|
|
} else {
|
|
if ($data[ 'is_differ_new_user' ] && $member_info && empty($is_first_member)) {
|
|
$bargain_money = mt_rand(1, ( $data[ 'aged_tall' ] * 100 ));
|
|
} else {
|
|
$bargain_money = mt_rand(1, ( $need_money * 100 ));
|
|
}
|
|
}
|
|
}
|
|
$bargain_money = $bargain_money / 100;
|
|
} else {
|
|
if (( $data[ 'curr_num' ] + 1 ) >= $data[ 'need_num' ]) return $need_money;
|
|
|
|
$bargain_money = round(mt_rand(( $average_bargain_money - $average_bargain_money * ( 1 - $rate ) ) * 100, ( $average_bargain_money + $average_bargain_money * ( 1 - $rate ) ) * 100), 2);
|
|
$bargain_money /= 100;
|
|
}
|
|
|
|
return $bargain_money;
|
|
}
|
|
|
|
/**
|
|
* 关闭到了时间的砍价
|
|
* @param $launch_id
|
|
*/
|
|
public function cronCloseBargainLaunch($launch_id)
|
|
{
|
|
$launch_info = model('promotion_bargain_launch')->getInfo([ [ 'launch_id', '=', $launch_id ], [ 'status', '=', 0 ] ]);
|
|
if (!empty($launch_info)) {
|
|
if ($launch_info[ 'curr_price' ] == $launch_info[ 'floor_price' ]) {
|
|
$data = [ 'status' => 1 ];
|
|
} else {
|
|
// 未砍到低价都算失败
|
|
$data = [ 'status' => 2 ];
|
|
}
|
|
model('promotion_bargain_launch')->update($data, [ [ 'launch_id', '=', $launch_id ], [ 'status', '=', 0 ] ]);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 商品营销活动标识
|
|
* @param $discount_id
|
|
* @param int $sku_id
|
|
*/
|
|
private function modifyPromotionAddon($bargain_id, $is_delete = false)
|
|
{
|
|
$goods = new Goods();
|
|
$condition = [
|
|
[ 'bargain_id', '=', $bargain_id ]
|
|
];
|
|
$goods_id = model('promotion_bargain')->getValue($condition, 'goods_id');
|
|
|
|
$goods->modifyPromotionAddon($goods_id, [ 'bargain' => $bargain_id ], $is_delete);
|
|
|
|
}
|
|
|
|
/**
|
|
* 判断规格值是否禁用
|
|
* @param $bargain_id
|
|
* @param $site_id
|
|
* @param $goods
|
|
* @return false|string
|
|
*/
|
|
public function getGoodsSpecFormat($bargain_id, $site_id, $goods_spec_format = '', $sku_id = 0)
|
|
{
|
|
//获取活动参与的商品sku_ids
|
|
$sku_ids = model('promotion_bargain_goods')->getColumn([ [ 'bargain_id', '=', $bargain_id ], [ 'site_id', '=', $site_id ] ], 'sku_id');
|
|
$goods_model = new Goods();
|
|
if ($sku_id == 0) {
|
|
$res = $goods_model->getGoodsSpecFormat($sku_ids, $goods_spec_format);
|
|
} else {
|
|
$res = $goods_model->getEmptyGoodsSpecFormat($sku_ids, $sku_id);
|
|
}
|
|
return $res;
|
|
}
|
|
|
|
/**
|
|
*
|
|
* @param $param
|
|
* @return array
|
|
*/
|
|
public function orderPay($param)
|
|
{
|
|
//获取砍价id
|
|
$bargain_id = model('promotion_bargain_launch')->getValue([ [ 'order_id', '=', $param[ 'order_id' ] ] ], 'bargain_id');
|
|
if ($bargain_id != 0) {
|
|
//更新砍价销量
|
|
model('promotion_bargain')->setInc([ [ 'bargain_id', '=', $bargain_id ] ], 'sale_num');
|
|
|
|
//获取sku_id
|
|
$sku_id = model('order_goods')->getValue([ [ 'order_id', '=', $param[ 'order_id' ] ] ], 'sku_id');
|
|
if ($sku_id != 0) {
|
|
model('promotion_bargain_goods')->setInc([ [ 'bargain_id', '=', $bargain_id ], [ 'sku_id', '=', $sku_id ] ], 'sale_num');
|
|
}
|
|
}
|
|
return $this->success();
|
|
}
|
|
|
|
/**
|
|
* 订单关闭
|
|
* @param $param
|
|
* @return array
|
|
*/
|
|
public function orderClose($param)
|
|
{
|
|
//获取砍价id
|
|
$bargain_info = model('promotion_bargain_launch')->getInfo([ [ 'order_id', '=', $param[ 'order_id' ] ] ], 'bargain_id,sku_id');
|
|
if (!empty($bargain_info)) {
|
|
$num = model('order_goods')->getValue([ [ 'order_id', '=', $param[ 'order_id' ] ], [ 'sku_id', '=', $bargain_info[ 'sku_id' ] ] ], 'num');
|
|
$param = [
|
|
'bargain_id' => $bargain_info[ 'bargain_id' ],
|
|
'sku_id' => $bargain_info[ 'sku_id' ],
|
|
'num' => $num
|
|
];
|
|
$this->incStock($param);
|
|
}
|
|
return $this->success();
|
|
}
|
|
|
|
/**
|
|
* 订单退款
|
|
* @param $param
|
|
* @return array
|
|
*/
|
|
public function orderGoodsRefund($param)
|
|
{
|
|
|
|
if ($param[ 'delivery_status' ] == Order::DELIVERY_WAIT) {
|
|
$order_info = model('order')->getInfo([ [ 'order_id', '=', $param[ 'order_id' ] ] ], 'promotion_type');
|
|
if (!empty($order_info) && $order_info[ 'promotion_type' ] == 'bargain') {
|
|
$bargain_info = model('promotion_bargain_launch')->getInfo([ [ 'order_id', '=', $param[ 'order_id' ] ] ], 'bargain_id,sku_id');
|
|
if (!empty($bargain_info)) {
|
|
$param = [
|
|
'bargain_id' => $bargain_info[ 'bargain_id' ],
|
|
'sku_id' => $bargain_info[ 'sku_id' ],
|
|
'num' => $param[ "num" ]
|
|
];
|
|
$this->incStock($param);
|
|
|
|
model('promotion_bargain')->setDec([ [ 'bargain_id', '=', $bargain_info[ 'bargain_id' ] ] ], 'sale_num');
|
|
|
|
model('promotion_bargain_goods')->setDec([ [ 'bargain_id', '=', $bargain_info[ 'bargain_id' ] ], [ 'sku_id', '=', $bargain_info[ 'sku_id' ] ] ], 'sale_num');
|
|
|
|
}
|
|
}
|
|
}
|
|
|
|
return $this->success();
|
|
}
|
|
|
|
/**
|
|
* 获取用户正在砍价中的商品
|
|
* @param $member_id
|
|
* @return array
|
|
*/
|
|
public function getBargainingGoodsId($member_id)
|
|
{
|
|
$list = model('promotion_bargain_launch')->getList([ [ 'member_id', '=', $member_id ], [ 'status', '=', 0 ] ], 'goods_id', '', 'a', [], 'goods_id');
|
|
$goods_id = [];
|
|
if (!empty($list)) $goods_id = array_column($list, 'goods_id');
|
|
return $goods_id;
|
|
}
|
|
|
|
|
|
/**
|
|
* 增加库存
|
|
* @param $param
|
|
*/
|
|
public function incStock($param)
|
|
{
|
|
$condition = array (
|
|
[ "sku_id", "=", $param[ "sku_id" ] ],
|
|
[ "bargain_id", "=", $param[ "bargain_id" ] ],
|
|
);
|
|
$num = $param[ "num" ];
|
|
$sku_info = model("promotion_bargain_goods")->getInfo($condition, "goods_id,bargain_stock");
|
|
if (empty($sku_info))
|
|
return $this->error(-1, "");
|
|
|
|
//编辑sku库存
|
|
$result = model("promotion_bargain_goods")->setInc($condition, "bargain_stock", $num);
|
|
|
|
|
|
return $this->success($result);
|
|
}
|
|
|
|
/**
|
|
* 减少库存
|
|
* @param $param
|
|
*/
|
|
public function decStock($param)
|
|
{
|
|
|
|
$num = $param[ "num" ];
|
|
$condition = array (
|
|
[ "sku_id", "=", $param[ "sku_id" ] ],
|
|
[ "bargain_id", "=", $param[ "bargain_id" ] ],
|
|
);
|
|
$sku_info = Db::name("promotion_bargain_goods")->where($condition)->field("goods_id,bargain_stock,bargain_name")->lock(true)->find();
|
|
|
|
if (empty($sku_info)) {
|
|
return $this->error();
|
|
}
|
|
|
|
if ($sku_info[ "bargain_stock" ] < $num) {
|
|
return $this->error('', $sku_info[ "bargain_name" ] . "库存不足!");
|
|
}
|
|
//编辑sku库存
|
|
$result = model("promotion_bargain_goods")->setDec($condition, "bargain_stock", $num);
|
|
|
|
if ($result === false) {
|
|
return $this->error();
|
|
}
|
|
|
|
|
|
return $this->success($result);
|
|
}
|
|
|
|
/**
|
|
* 商品用到的分类
|
|
* @param $condition
|
|
* @return array
|
|
*/
|
|
public function getGoodsCategoryIds($condition)
|
|
{
|
|
$cache_name = "shop_bargain_goods_category_" . md5(json_encode($condition));
|
|
$cache_time = 60;
|
|
$cache_res = Cache::get($cache_name);
|
|
if (empty($cache_res) || time() - $cache_res[ 'time' ] > $cache_time) {
|
|
$list = Db::name('promotion_bargain')
|
|
->alias('pb')
|
|
->join('goods g', 'pb.goods_id = g.goods_id', 'inner')
|
|
->where($condition)
|
|
->group('g.category_id')
|
|
->column('g.category_id');
|
|
$category_ids = trim(join('0', $list), ',');
|
|
$category_id_arr = array_unique(explode(',', $category_ids));
|
|
Cache::set($cache_name, [ 'time' => time(), 'data' => $category_id_arr ]);
|
|
} else {
|
|
$category_id_arr = $cache_res[ 'data' ];
|
|
}
|
|
return $this->success($category_id_arr);
|
|
}
|
|
|
|
public function urlQrcode($page, $qrcode_param, $promotion_type, $site_id)
|
|
{
|
|
$params = [
|
|
'site_id' => $site_id,
|
|
'data' => $qrcode_param,
|
|
'page' => $page,
|
|
'promotion_type' => $promotion_type,
|
|
'h5_path' => $page . '?b_id=' . $qrcode_param[ 'b_id' ],
|
|
'qrcode_path' => 'upload/qrcode/bargain',
|
|
'qrcode_name' => [
|
|
'h5_name' => 'bargain_qrcode_' . $promotion_type . '_h5_' . $qrcode_param[ 'b_id' ] . '_' . $site_id,
|
|
'weapp_name' => 'bargain_qrcode_' . $promotion_type . '_weapp_' . $qrcode_param[ 'b_id' ] . '_' . $site_id
|
|
]
|
|
];
|
|
|
|
$solitaire = event('ExtensionInformation', $params);
|
|
return $this->success($solitaire[ 0 ]);
|
|
}
|
|
|
|
/**
|
|
* 浏览量增加
|
|
* @param $condition
|
|
* @return array
|
|
* @throws \think\db\exception\DbException
|
|
*/
|
|
public function bargainBrowseInc($condition)
|
|
{
|
|
$res = model('promotion_bargain')->setInc($condition, 'browse_num');
|
|
return $this->success($res);
|
|
}
|
|
|
|
/**
|
|
* 分享量增加
|
|
* @param $condition
|
|
* @return array
|
|
* @throws \think\db\exception\DbException
|
|
*/
|
|
public function bargainShareInc($condition)
|
|
{
|
|
$res = model('promotion_bargain')->setInc($condition, 'share_num');
|
|
return $this->success($res);
|
|
}
|
|
|
|
/**
|
|
* 砍价成功
|
|
* @param $data
|
|
*/
|
|
public function bargainCompleteMessage($data)
|
|
{
|
|
//发送短信
|
|
$sms_model = new Sms();
|
|
$launch_id = $data[ "launch_id" ];
|
|
$launch_info = model("promotion_bargain_launch")->getInfo([ [ "launch_id", "=", $launch_id ] ]);
|
|
|
|
$member_model = new Member();
|
|
$member_info_result = $member_model->getMemberInfo([ [ "member_id", "=", $launch_info[ "member_id" ] ] ]);
|
|
$member_info = $member_info_result[ "data" ];
|
|
|
|
$var_parse = array (
|
|
"sku_name" => $launch_info[ "sku_name" ],//商品名称
|
|
);
|
|
$data[ "sms_account" ] = $member_info[ "mobile" ];//手机号
|
|
$data[ "var_parse" ] = $var_parse;
|
|
|
|
Log::write('bargainCompleteMessage-sms-' . json_encode($data));
|
|
|
|
$sms_model->sendMessage($data);
|
|
|
|
|
|
if (!empty($member_info) && !empty($member_info[ "wx_openid" ])) {
|
|
$wechat_model = new WechatMessage();
|
|
$data[ "openid" ] = $member_info[ "wx_openid" ];
|
|
$data[ "template_data" ] = [
|
|
'keyword1' => str_sub($launch_info[ 'sku_name' ]),
|
|
'keyword2' => $launch_info[ 'price' ],
|
|
'keyword3' => $launch_info[ 'floor_price' ],
|
|
'keyword4' => time_to_date($launch_info[ 'end_time' ]),
|
|
];
|
|
$data[ "page" ] = 'pages_promotion/bargain/detail?l_id=' . $launch_info[ 'launch_id' ] . '&b_id=' . $launch_info[ 'bargain_id' ];
|
|
Log::write('bargainCompleteMessage-wechat-' . json_encode($data));
|
|
$wechat_model->sendMessage($data);
|
|
}
|
|
|
|
//发送订阅消息
|
|
if (!empty($member_info) && !empty($member_info[ "weapp_openid" ])) {
|
|
$weapp_model = new WeappMessage();
|
|
$data[ "openid" ] = $member_info[ "weapp_openid" ];
|
|
$data[ "template_data" ] = [
|
|
'thing1' => [
|
|
'value' => str_sub($launch_info[ 'sku_name' ])
|
|
],
|
|
'amount2' => [
|
|
'value' => $launch_info[ 'price' ]
|
|
],
|
|
'amount8' => [
|
|
'value' => $launch_info[ 'floor_price' ]
|
|
],
|
|
'time3' => [
|
|
'value' => time_to_date($launch_info[ 'end_time' ])
|
|
],
|
|
];
|
|
$data[ "page" ] = 'pages_promotion/bargain/detail?l_id=' . $launch_info[ 'launch_id' ] . '&b_id=' . $launch_info[ 'bargain_id' ];
|
|
Log::write('bargainCompleteMessage-wechat-' . json_encode($data));
|
|
$weapp_model->sendMessage($data);
|
|
}
|
|
}
|
|
|
|
} |