70 lines
2.5 KiB
PHP
70 lines
2.5 KiB
PHP
<?php
|
||
|
||
// +----------------------------------------------------------------------
|
||
// | CRMEB [ CRMEB赋能开发者，助力企业发展 ]
|
||
// +----------------------------------------------------------------------
|
||
// | Copyright (c) 2016~2022 https://www.crmeb.com All rights reserved.
|
||
// +----------------------------------------------------------------------
|
||
// | Licensed CRMEB并不是自由软件，未经许可不能去掉CRMEB相关版权
|
||
// +----------------------------------------------------------------------
|
||
// | Author: CRMEB Team <admin@crmeb.com>
|
||
// +----------------------------------------------------------------------
|
||
|
||
|
||
namespace app\common\dao\store\broadcast;
|
||
|
||
|
||
use app\common\dao\BaseDao;
|
||
use app\common\model\BaseModel;
|
||
use app\common\model\store\broadcast\BroadcastRoomGoods;
|
||
use app\common\repositories\store\order\StoreCartRepository;
|
||
|
||
class BroadcastRoomGoodsDao extends BaseDao
|
||
{
|
||
|
||
protected function getModel(): string
|
||
{
|
||
return BroadcastRoomGoods::class;
|
||
}
|
||
|
||
public function clear($id)
|
||
{
|
||
return BroadcastRoomGoods::getDB()->where('broadcast_room_id', $id)->delete();
|
||
}
|
||
|
||
public function goodsId($id)
|
||
{
|
||
return BroadcastRoomGoods::getDB()->where('broadcast_room_id', $id)->column('broadcast_goods_id');
|
||
}
|
||
|
||
public function rmGoods($goodsId, $roomId)
|
||
{
|
||
return BroadcastRoomGoods::getDB()->where('broadcast_room_id', $roomId)->where('broadcast_goods_id', $goodsId)->delete();
|
||
}
|
||
|
||
public function getGoodsList($roomId, $page, $limit)
|
||
{
|
||
$query = BroadcastRoomGoods::getDB()->where('broadcast_room_id', $roomId);
|
||
$count = $query->count();
|
||
$list = $query->page($page, $limit)->with('goods.product')->select()->toArray();
|
||
$ids = array_column($list, 'broadcast_goods_id');
|
||
if (count($ids)) {
|
||
$sourcePayInfo = app()->make(StoreCartRepository::class)->getSourcePayInfo(1, $ids);
|
||
$data = [];
|
||
foreach ($sourcePayInfo as $item) {
|
||
$data[$item['source_id']] = $item;
|
||
}
|
||
foreach ($list as $k => $goods) {
|
||
$list[$k]['goods']['pay_num'] = $data[$goods['broadcast_goods_id']]['pay_num'] ?? 0;
|
||
$list[$k]['goods']['pay_price'] = $data[$goods['broadcast_goods_id']]['pay_price'] ?? 0;
|
||
}
|
||
}
|
||
return compact('list', 'count');
|
||
}
|
||
|
||
public function deleteGoods($goodsId)
|
||
{
|
||
return BroadcastRoomGoods::getDB()->where('broadcast_goods_id', $goodsId)->delete();
|
||
}
|
||
}
|