// +---------------------------------------------------------------------- namespace app\dao\order; use app\dao\BaseDao; use app\model\order\StoreOrder; /** * 订单 * Class StoreOrderDao * @package app\dao\order */ class StoreOrderDao extends BaseDao { /** * 限制精确查询字段 * @var string[] */ protected $withField = ['uid', 'order_id', 'real_name', 'user_phone', 'title']; /** * @return string */ protected function setModel(): string { return StoreOrder::class; } /** * 订单搜索 * @param array $where * @param bool $search * @return \crmeb\basic\BaseModel|mixed|\think\Model * @throws \ReflectionException */ public function search(array $where = [], bool $search = false) { $isDel = isset($where['is_del']) && $where['is_del'] !== '' && $where['is_del'] != -1; $realName = $where['real_name'] ?? ''; $fieldKey = $where['field_key'] ?? ''; $fieldKey = $fieldKey == 'all' ? '' : $fieldKey; $status = $where['status'] ?? ''; unset($where['status']); return parent::search($where, $search)->when($isDel, function ($query) use ($where) { $query->where('is_del', $where['is_del']); })->when(isset($where['is_system_del']), function ($query) { $query->where('is_system_del', 0); })->when($status !== '', function ($query) use ($where, $status) { switch ((int)$status) { case 0://未支付 $query->where('paid', 0)->where('status', 0)->where('refund_status', 0)->where('is_del', 0); break; case 1://已支付 未发货 $query->where('paid', 1)->where('status', 0)->whereIn('refund_status', [0, 3])->when(isset($where['shipping_type']), function ($query) { $query->where('shipping_type', 1); })->where('is_del', 0); break; case 7://已支付 部分发货 $query->where('paid', 1)->where('status', 4)->whereIn('refund_status', [0, 3])->where('is_del', 0); break; case 2://已支付 待收货 $query->where('paid', 1)->where('status', 1)->whereIn('refund_status', [0, 3])->where('is_del', 0); break; case 3:// 已支付 已收货 待评价 $query->where('paid', 1)->where('status', 2)->whereIn('refund_status', [0, 3])->where('is_del', 0); break; case 4:// 交易完成 $query->where('paid', 1)->where('status', 3)->whereIn('refund_status', [0, 3])->where('is_del', 0); break; case 5://已支付 待核销 $query->where('paid', 1)->where('status', 0)->where('refund_status', 0)->where('shipping_type', 2)->where('is_del', 0); break; case 6://已支付 已核销 没有退款 $query->where('paid', 1)->whereIn('status', [2,3])->where('refund_status', 0)->where('shipping_type', 2)->where('is_del', 0); break; case -1://退款中 $query->where('paid', 1)->whereIn('refund_status', [1, 4])->where('is_del', 0); break; case -2://已退款 $query->where('paid', 1)->where('refund_status', 2)->where('is_del', 0); break; case -3://退款 $query->where('paid', 1)->whereIn('refund_status', [1, 2, 4])->where('is_del', 0); break; case -4://已删除 $query->where('is_del', 1); break; case 9://全部用户未删除的订单 $query->whereIn('refund_status', [0, 3])->where('is_del', 0); break; } })->when(isset($where['paid']) && $where['paid'] !== '', function ($query) use ($where) { if (in_array($where['paid'], [0, 1])) { $query->where('paid', $where['paid']); } })->when(isset($where['order_status']) && $where['order_status'] !== '', function ($query) use ($where) { switch ((int)$where['order_status']) { case 0://未发货 $query->where('status', 0)->where('refund_status', 0)->where('is_del', 0); break; case 1://已发货 $query->where('paid', 1)->where('status', 1)->whereIn('refund_status', [0, 3])->when(isset($where['shipping_type']), function ($query) { $query->where('shipping_type', 1); })->where('is_del', 0); break; case 2://已收货 $query->where('paid', 1)->where('status', 2)->whereIn('refund_status', [0, 3])->where('is_del', 0); break; case 3://已完成 $query->where('paid', 1)->where('status', 3)->whereIn('refund_status', [0, 3])->where('is_del', 0); break; case -2://已退款 $query->where('paid', 1)->where('status', -2)->where('is_del', 0); break; } })->when(isset($where['type']), function ($query) use ($where) { switch ($where['type']) { case 1: $query->where('combination_id', 0)->where('seckill_id', 0)->where('bargain_id', 0)->where('advance_id', 0); break; case 2: $query->where('pink_id|combination_id', ">", 0); break; case 3: $query->where('seckill_id', ">", 0); break; case 4: $query->where('bargain_id', ">", 0); break; case 5: $query->where('advance_id', ">", 0); break; case 6: $query->where(function ($query) { $query->where('one_brokerage', '>', 0)->whereOr('two_brokerage', '>', 0); }); break; } })->when(isset($where['pay_type']), function ($query) use ($where) { switch ($where['pay_type']) { case 1: $query->where('pay_type', 'weixin'); break; case 2: $query->where('pay_type', 'yue'); break; case 3: $query->where('pay_type', 'offline'); break; case 4: $query->where('pay_type', 'alipay'); break; } })->when($realName && $fieldKey && in_array($fieldKey, $this->withField), function ($query) use ($where, $realName, $fieldKey) { if ($fieldKey !== 'title') { $query->where(trim($fieldKey), trim($realName)); } else { $query->where('id', 'in', function ($que) use ($where) { $que->name('store_order_cart_info')->whereIn('product_id', function ($q) use ($where) { $q->name('store_product')->whereLike('store_name|keyword', '%' . $where['real_name'] . '%')->field(['id'])->select(); })->field(['oid'])->select(); }); } })->when($realName && !$fieldKey, function ($query) use ($where) { $query->where(function ($que) use ($where) { $que->whereLike('order_id|real_name|user_phone', '%' . $where['real_name'] . '%')->whereOr('uid', 'in', function ($q) use ($where) { $q->name('user')->whereLike('nickname|uid|phone', '%' . $where['real_name'] . '%')->field(['uid'])->select(); })->whereOr('id', 'in', function ($que) use ($where) { $que->name('store_order_cart_info')->whereIn('product_id', function ($q) use ($where) { $q->name('store_product')->whereLike('store_name|keyword', '%' . $where['real_name'] . '%')->field(['id'])->select(); })->field(['oid'])->select(); }); }); })->when(isset($where['store_id']) && $where['store_id'], function ($query) use ($where) { $query->where('store_id', $where['store_id']); })->when(isset($where['unique']), function ($query) use ($where) { $query->where('unique', $where['unique']); })->when(isset($where['is_remind']), function ($query) use ($where) { $query->where('is_remind', $where['is_remind']); })->when(isset($where['refundTypes']) && $where['refundTypes'] != '', function ($query) use ($where) { switch ((int)$where['refundTypes']) { case 1: $query->where('refund_type', 'in', '1,2'); break; case 2: $query->where('refund_type', 4); break; case 3: $query->where('refund_type', 5); break; case 4: $query->where('refund_type', 6); break; } })->when(isset($where['is_refund']) && $where['is_refund'] !== '', function ($query) use ($where) { if ($where['is_refund'] == 1) { $query->where('refund_status', 2); } else { $query->where('refund_status', 0); } }); } /** * 获取某一个月订单数量 * @param array $where * @param string $month * @return int */ public function getMonthCount(array $where, string $month) { return $this->search($where)->whereMonth('add_time', $month)->count(); } /** * 订单搜索列表 * @param array $where * @param array $field * @param int $page * @param int $limit * @param array $with * @return array * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException */ public function getList(array $where, array $field, int $page = 0, int $limit = 0, array $with = []) { return $this->search($where)->field($field)->with($with)->when($page && $limit, function ($query) use ($page, $limit) { $query->page($page, $limit); })->order('pay_time DESC,id DESC')->select()->toArray(); } /** * 订单搜索列表 * @param array $where * @param array $field * @param int $page * @param int $limit * @param array $with * @param string $order * @return array * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException */ public function getOrderList(array $where, array $field, int $page = 0, int $limit = 0, array $with = [], $order = 'add_time DESC,id DESC') { return $this->search($where)->field($field)->with(array_merge(['user', 'spread', 'refund'], $with))->when($page && $limit, function ($query) use ($page, $limit) { $query->page($page, $limit); })->order($order)->select()->toArray(); } /** * 获取订单总数 * @param array $where * @param bool $search * @return int * @throws \ReflectionException */ public function count(array $where = [], bool $search = true) { return $this->search($where, $search)->count(); } /** * 聚合查询 * @param array $where * @param string $field * @param string $together * @return int */ public function together(array $where, string $field, string $together = 'sum') { if (!in_array($together, ['sum', 'max', 'min', 'avg'])) { return 0; } return $this->search($where)->{$together}($field); } /** * 查找指定条件下的订单数据以数组形式返回 * @param array $where * @param string $field * @param string $key * @param string $group * @return array */ public function column(array $where, string $field, string $key = '', string $group = '') { return $this->search($where)->when($group, function ($query) use ($group) { $query->group($group); })->column($field, $key); } /** * 获取订单id下没有删除的订单数量 * @param array $ids * @return int */ public function getOrderIdsCount(array $ids) { return $this->getModel()->whereIn('id', $ids)->where('is_del', 0)->count(); } /** * 获取一段时间内订单列表 * @param $datebefor * @param $dateafter * @return mixed */ public function orderAddTimeList($datebefor, $dateafter, $timeType = "week") { return $this->getModel()->where('add_time', 'between time', [$datebefor, $dateafter])->where('paid', 1)->where('refund_status', 0)->whereIn('pid', [-1, 0]) ->when($timeType, function ($query) use ($timeType) { $timeUnix = "%w"; switch ($timeType) { case "week" : $timeUnix = "%w"; break; case "month" : $timeUnix = "%d"; break; case "year" : $timeUnix = "%m"; break; case "30" : $timeUnix = "%m-%d"; break; } $query->field("FROM_UNIXTIME(add_time,'$timeUnix') as day,count(*) as count,sum(pay_price) as price"); $query->group("FROM_UNIXTIME(add_time, '$timeUnix')"); }) ->order('add_time asc') ->select()->toArray(); } /** * 统计总数上期 * @param $pre_datebefor * @param $pre_dateafter * @return array|\think\Model|null * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException */ public function preTotalFind($pre_datebefor, $pre_dateafter) { return $this->getModel()->where('add_time', 'between time', [$pre_datebefor, $pre_dateafter]) ->field("count(*) as count,sum(pay_price) as price") ->find(); } /** * 获取一段时间内订单列表 * @param $now_datebefor * @param $now_dateafter * @return mixed */ public function nowOrderList($now_datebefor, $now_dateafter, $timeType = "week") { return $this->getModel()->where('add_time', 'between time', [$now_datebefor, $now_dateafter])->where('paid', 1)->where('refund_status', 0)->whereIn('pid', [-1, 0]) ->when($timeType, function ($query) use ($timeType) { $timeUnix = "%w"; switch ($timeType) { case "week" : $timeUnix = "%w"; break; case "month" : $timeUnix = "%d"; break; case "year" : $timeUnix = "%m"; break; } $query->field("FROM_UNIXTIME(add_time,'$timeUnix') as day,count(*) as count,sum(pay_price) as price"); $query->group("FROM_UNIXTIME(add_time, '$timeUnix')"); }) ->order('add_time asc') ->select()->toArray(); } /** * 获取订单数量 * @return int */ public function storeOrderCount() { return $this->search(['paid' => 1, 'is_del' => 0, 'refund_status' => 0, 'status' => 1, 'shipping_type' => 1, 'pid' => 0])->count(); } /** * 获取特定时间内订单总价 * @param $time * @return float */ public function todaySales($time) { return $this->search(['paid' => 1, 'refund_status' => 0, 'time' => $time ?: 'today', 'timekey' => 'pay_time', 'pid' => 0])->sum('pay_price'); } /** * 获取特定时间内订单总价 * @param $time * @return float */ public function thisWeekSales($time) { return $this->search(['paid' => 1, 'refund_status' => 0, 'time' => $time ?: 'week', 'timeKey' => 'pay_time', 'pid' => 0])->sum('pay_price'); } /** * 总销售额 * @return float */ public function totalSales($time) { return $this->search(['paid' => 1, 'refund_status' => 0, 'time' => $time ?: 'today', 'timekey' => 'pay_time', 'pid' => 0])->sum('pay_price'); } public function newOrderUpdates($newOrderId) { return $this->getModel()->where('order_id', 'in', $newOrderId)->update(['is_remind' => 1]); } /** * 获取特定时间内订单量 * @param $time * @return float */ public function todayOrderVisit($time, $week) { switch ($week) { case 1: return $this->search(['time' => $time ?: 'today', 'timeKey' => 'add_time', 'paid' => 1, 'refund_status' => 0, 'pid' => 0])->count(); case 2: return $this->search(['time' => $time ?: 'week', 'timeKey' => 'add_time', 'paid' => 1, 'refund_status' => 0, 'pid' => 0])->count(); } } /** * 获取订单详情 * @param string $key * @param int $uid * @param array $with * @return array|\think\Model|null * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException */ public function getUserOrderDetail(string $key, int $uid, $with = []) { $where = ['order_id|unique' => $key, 'is_del' => 0]; if ($uid > 0) $where = $where + ['uid' => $uid]; return $this->getOne($where, '*', $with); } /** * 获取用户推广订单 * @param array $where * @param string $field * @param int $page * @param int $limit * @param array $with * @return array * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException */ public function getStairOrderList(array $where, string $field, int $page, int $limit, array $with = []) { return $this->search($where)->with($with)->field($field)->page($page, $limit)->order('id DESC')->select()->toArray(); } /** * 订单每月统计数据 * @param int $page * @param int $limit * @return array */ public function getOrderDataPriceCount(array $where, array $field, int $page, int $limit) { return $this->search($where) ->field($field)->group("FROM_UNIXTIME(add_time, '%Y-%m-%d')") ->order('add_time DESC')->page($page, $limit)->select()->toArray(); } /** * 获取当前时间到指定时间的支付金额 管理员 * @param $start 开始时间 * @param $stop 结束时间 * @return mixed */ public function chartTimePrice($start, $stop) { return $this->search(['pid' => 0, 'is_del' => 0, 'paid' => 1, 'refund_status' => [0, 3]]) ->where('add_time', '>=', $start) ->where('add_time', '<', $stop) ->field('sum(pay_price) as num,FROM_UNIXTIME(add_time, \'%Y-%m-%d\') as time') ->group("FROM_UNIXTIME(add_time, '%Y-%m-%d')") ->order('add_time ASC')->select()->toArray(); } /** * 获取当前时间到指定时间的支付订单数 管理员 * @param $start 开始时间 * @param $stop 结束时间 * @return mixed */ public function chartTimeNumber($start, $stop) { return $this->search(['pid' => 0, 'is_del' => 0, 'paid' => 1, 'refund_status' => [0, 3]]) ->where('add_time', '>=', $start) ->where('add_time', '<', $stop) ->field('count(id) as num,FROM_UNIXTIME(add_time, \'%Y-%m-%d\') as time') ->group("FROM_UNIXTIME(add_time, '%Y-%m-%d')") ->order('add_time ASC')->select()->toArray(); } /** * 获取用户已购买此活动商品的个数 * @param $uid * @param $type * @param $typeId * @return int */ public function getBuyCount($uid, $type, $typeId): int { return $this->getModel() ->where('uid', $uid) ->where($type, $typeId) ->where(function ($query) { $query->where('paid', 1)->whereOr(function ($query1) { $query1->where('paid', 0)->where('is_del', 0); }); })->value('sum(total_num)') ?? 0; } /** * 获取没有支付的订单列表 * @param array|string[] $field * @return array * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException */ public function getOrderUnPaidList(array $field = ['*']) { return $this->getModel()->where(['paid' => 0, 'is_del' => 0, 'status' => 0, 'refund_status' => 0]) ->where('pay_type', '<>', 'offline')->field($field)->select(); } /** 根据时间获取营业额 * @param array $where * @return float|int */ public function getOrderMoneyByTime(array $where) { if (isset($where['day'])) { return $this->getModel()->where(['refund_status' => 0, 'paid' => 1])->whereDay('add_time', date("Y-m-d", strtotime($where['day'])))->sum('pay_price'); } return 0; } /** * 用户趋势数据 * @param $time * @param $type * @param $timeType * @return mixed */ public function getTrendData($time, $type, $timeType, $str) { return $this->getModel()->when($type != '', function ($query) use ($type) { $query->where('channel_type', $type); })->where(function ($query) use ($time) { if ($time[0] == $time[1]) { $query->whereDay('pay_time', $time[0]); } else { // $time[1] = date('Y/m/d', strtotime($time[1]) + 86400); $query->whereTime('pay_time', 'between', $time); } })->field("FROM_UNIXTIME(pay_time,'$timeType') as days,$str as num") ->group('days')->select()->toArray(); } /** * 用户地域数据 * @param $time * @param $userType * @return mixed */ public function getRegion($time, $userType) { return $this->getModel()->when($userType != '', function ($query) use ($userType) { $query->where('channel_type', $userType); })->where(function ($query) use ($time) { if ($time[0] == $time[1]) { $query->whereDay('pay_time', $time[0]); } else { // $time[1] = date('Y/m/d', strtotime($time[1]) + 86400); $query->whereTime('pay_time', 'between', $time); } })->field('sum(pay_price) as payPrice,province') ->group('province')->select()->toArray(); } /** * 商品趋势 * @param $time * @param $timeType * @param $field * @param $str * @return mixed */ public function getProductTrend($time, $timeType, $field, $str, $orderStatus = '') { return $this->getModel()->where(function ($query) use ($field, $orderStatus) { if ($field == 'pay_time') { $query->where('paid', 1)->where('pid', '>=', 0); } elseif ($field == 'refund_reason_time') { $query->where('paid', 1)->where('pid', '>=', 0)->where('refund_status', '>', 0); } elseif ($field == 'add_time') { if ($orderStatus == 'pay') { $query->where('paid', 1)->where('pid', '>=', 0)->where('refund_status', 0); } elseif ($orderStatus == 'refund') { $query->where('paid', 1)->where('pid', '>=', 0)->where('refund_status', '>', 0); } } })->where(function ($query) use ($time, $field) { if ($time[0] == $time[1]) { $query->whereDay($field, $time[0]); } else { $query->whereTime($field, 'between', $time); } })->where('pid', '>=', 0)->field("FROM_UNIXTIME($field,'$timeType') as days,$str as num")->group('days')->select()->toArray(); } /** 按照支付时间统计支付金额 * @param array $where * @param string $sumField * @return mixed */ public function getDayTotalMoney(array $where, string $sumField) { return $this->search($where) ->when(isset($where['timeKey']), function ($query) use ($where) { $query->whereBetweenTime('pay_time', $where['timeKey']['start_time'], $where['timeKey']['end_time']); }) ->sum($sumField); } /**时间段订单数统计 * @param array $where * @param string $countField * @return int */ public function getDayOrderCount(array $where, string $countField = "*") { return $this->search($where) ->when(isset($where['timeKey']), function ($query) use ($where) { $query->whereBetweenTime('pay_time', $where['timeKey']['start_time'], $where['timeKey']['end_time']); }) ->count($countField); } /** 时间分组订单付款金额统计 * @param array $where * @param string $sumField * @return mixed */ public function getDayGroupMoney(array $where, string $sumField, string $group) { return $this->search($where) ->when(isset($where['timeKey']), function ($query) use ($where, $sumField, $group) { $query->whereBetweenTime('pay_time', $where['timeKey']['start_time'], $where['timeKey']['end_time']); $timeUinx = "%H"; if ($where['timeKey']['days'] == 1) { $timeUinx = "%H"; } elseif ($where['timeKey']['days'] == 30) { $timeUinx = "%Y-%m-%d"; } elseif ($where['timeKey']['days'] == 365) { $timeUinx = "%Y-%m"; } elseif ($where['timeKey']['days'] > 1 && $where['timeKey']['days'] < 30) { $timeUinx = "%Y-%m-%d"; } elseif ($where['timeKey']['days'] > 30 && $where['timeKey']['days'] < 365) { $timeUinx = "%Y-%m"; } $query->field("sum($sumField) as number,FROM_UNIXTIME($group, '$timeUinx') as time"); $query->group("FROM_UNIXTIME($group, '$timeUinx')"); }) ->order('pay_time ASC,id DESC')->select()->toArray(); } /**时间分组订单数统计 * @param array $where * @param string $sumField * @return mixed */ public function getOrderGroupCount(array $where, string $sumField = "*") { return $this->search($where) ->when(isset($where['timeKey']), function ($query) use ($where, $sumField) { $query->whereBetweenTime('pay_time', $where['timeKey']['start_time'], $where['timeKey']['end_time']); $timeUinx = "%H"; if ($where['timeKey']['days'] == 1) { $timeUinx = "%H"; } elseif ($where['timeKey']['days'] == 30) { $timeUinx = "%Y-%m-%d"; } elseif ($where['timeKey']['days'] == 365) { $timeUinx = "%Y-%m"; } elseif ($where['timeKey']['days'] > 1 && $where['timeKey']['days'] < 30) { $timeUinx = "%Y-%m-%d"; } elseif ($where['timeKey']['days'] > 30 && $where['timeKey']['days'] < 365) { $timeUinx = "%Y-%m"; } $query->field("count($sumField) as number,FROM_UNIXTIME(pay_time, '$timeUinx') as time"); $query->group("FROM_UNIXTIME(pay_time, '$timeUinx')"); }) ->order('pay_time ASC,id DESC')->select()->toArray(); } /**时间段支付订单人数 * @param $where * @return mixed */ public function getPayOrderPeople($where) { return $this->search($where) ->when(isset($where['timeKey']), function ($query) use ($where) { $query->whereBetweenTime('pay_time', $where['timeKey']['start_time'], $where['timeKey']['end_time']); }) ->field('uid') ->distinct(true) ->select()->toArray(); } /**时间段分组统计支付订单人数 * @param $where * @return mixed */ public function getPayOrderGroupPeople($where) { return $this->search($where) ->when(isset($where['timeKey']), function ($query) use ($where) { $query->whereBetweenTime('pay_time', $where['timeKey']['start_time'], $where['timeKey']['end_time']); if ($where['timeKey']['days'] == 1) { $timeUinx = "%H"; } elseif ($where['timeKey']['days'] == 30) { $timeUinx = "%Y-%m-%d"; } elseif ($where['timeKey']['days'] == 365) { $timeUinx = "%Y-%m"; } elseif ($where['timeKey']['days'] > 1 && $where['timeKey']['days'] < 30) { $timeUinx = "%Y-%m-%d"; } elseif ($where['timeKey']['days'] > 30 && $where['timeKey']['days'] < 365) { $timeUinx = "%Y-%m"; } else { $timeUinx = "%H"; } $query->field("count(distinct uid) as number,FROM_UNIXTIME(pay_time, '$timeUinx') as time"); $query->group("FROM_UNIXTIME(pay_time, '$timeUinx')"); }) ->order('pay_time ASC,id DESC')->select()->toArray(); } /**获取批量打印电子面单数据 * @param array $where * @param string $filed * @return array * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException */ public function getOrderDumpData(array $where, $filed = "*") { $where['status'] = 1; $where['refund_status'] = 0; $where['paid'] = 1; $where['is_del'] = 0; $where['shipping_type'] = 1; $where['is_system_del'] = 0; return $this->search($where)->field($filed)->select()->toArray(); } /** * @param array $where * @param string $field * @return array * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException */ public function getOrderListByWhere(array $where, $field = "*") { return $this->search($where)->field($field)->select()->toArray(); } /**批量修改订单 * @param array $ids * @param array $data * @param string|null $key * @return \crmeb\basic\BaseModel */ public function batchUpdateOrder(array $ids, array $data, ?string $key = null) { return $this->getModel()::whereIn(is_null($key) ? $this->getPk() : $key, $ids)->update($data); } /**根据orderid校验符合状态的发货数据 * @param $order_ids * @return array|\crmeb\basic\BaseModel * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException */ public function getCanDevlieryOrder($key, $value) { $model = $this->getModel(); if (is_array($value)) { $model = $model->whereIn($key, $value); } else { $model = $model->where($key, $value); } $model = $model->where(['status' => 0, 'is_del' => 0, 'paid' => 1, 'shipping_type' => 1, 'is_system_del' => 0, 'refund_status' => 0])->field('id, order_id')->select()->toArray(); return $model; } /** * 查询退款订单 * @param $where * @param $page * @param $limit * @return array * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException */ public function getRefundList($where, $page = 0, $limit = 0) { $model = $this->getModel() ->where('paid', 1)->where('is_system_del', 0) ->when($where['refund_type'] == 0, function ($query) use ($where) { $query->where('refund_type', '>', 0); }) ->when($where['order_id'] != '', function ($query) use ($where) { $query->where('order_id', $where['order_id']); }) ->when($where['refund_type'], function ($query) use ($where) { $query->where('refund_type', $where['refund_type']); }) ->when(is_array($where['refund_reason_time']), function ($query) use ($where) { $query->whereBetween('refund_reason_time', [strtotime($where['refund_reason_time'][0]), strtotime($where['refund_reason_time'][1]) + 86400]); }) ->with(array_merge(['user', 'spread'])); $count = $model->count(); $list = $model->when($page != 0 && $limit != 0, function ($query) use ($page, $limit) { $query->page($page, $limit); })->order('refund_reason_time desc')->select()->toArray(); return compact('list', 'count'); } /** * 订单搜索列表 * @param array $where * @param array $field * @param int $page * @param int $limit * @param array $with * @param string $order * @return array * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException */ public function getOutOrderList(array $where, array $field, int $page = 0, int $limit = 0, array $with = [], string $order = 'add_time DESC,id DESC'): array { return $this->search($where)->field($field)->with($with)->when($page && $limit, function ($query) use ($page, $limit) { $query->page($page, $limit); })->order($order)->select()->toArray(); } /** * 秒杀参与人统计 * @param $id * @param $keyword * @param int $page * @param int $limit * @return mixed */ public function seckillPeople($id, $keyword, $page = 0, $limit = 0) { return $this->getModel()->where('paid', 1)->whereIn('refund_type', [0, 3])->where('is_del', 0) ->when($id != 0, function ($query) use ($id) { $query->where('seckill_id', $id); })->when($keyword != '', function ($query) use ($keyword) { $query->where('real_name|uid|user_phone', 'like', '%' . $keyword . '%'); })->where('paid', 1)->field([ 'real_name', 'uid', 'user_phone', 'SUM(total_num) as goods_num', 'COUNT(id) as order_num', 'SUM(pay_price) as total_price', 'add_time' ])->group('uid')->order("add_time desc")->when($page && $limit, function ($query) use ($page, $limit) { $query->page($page, $limit); })->select()->toArray(); } /** * 秒杀订单统计 * @param $id * @param $where * @param int $page * @param int $limit * @return array * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException */ public function seckillOrder($id, $where, $page = 0, $limit = 0) { return $this->search($where)->where('seckill_id', $id) ->when($page && $limit, function ($query) use ($page, $limit) { $query->page($page, $limit); })->field(['order_id', 'real_name', 'status', 'pay_price', 'total_num', 'add_time', 'pay_time', 'paid'])->order('add_time desc')->select()->toArray(); } /** * 秒杀订单统计总数 * @param $id * @param $where * @return int * @throws \ReflectionException * @author: 吴汐 * @email: 442384644@qq.com * @date: 2023/8/31 */ public function seckillCount($id, $where) { return $this->search($where)->where('seckill_id', $id)->count(); } /** * 砍价订单统计 * @param $id * @param $where * @param int $page * @param int $limit * @return array * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException */ public function bargainStatisticsOrder($id, $where, $page = 0, $limit = 0) { return $this->search($where)->where('bargain_id', $id) ->when($page && $limit, function ($query) use ($page, $limit) { $query->page($page, $limit); })->field(['uid', 'order_id', 'real_name', 'status', 'pay_price', 'total_num', 'add_time', 'pay_time', 'paid'])->order('add_time desc')->select()->toArray(); } /** * 砍价订单统计数量 * @param $id * @param $where * @return int * @throws \ReflectionException * @author: 吴汐 * @email: 442384644@qq.com * @date: 2023/8/31 */ public function bargainStatisticsOrderCount($id, $where) { return $this->search($where)->where('bargain_id', $id)->count(); } /** * 拼团订单统计 * @param $id * @param $where * @param int $page * @param int $limit * @return array * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException */ public function combinationStatisticsOrder($id, $where, $page = 0, $limit = 0) { return $this->search($where)->where('combination_id', $id) ->when($page && $limit, function ($query) use ($page, $limit) { $query->page($page, $limit); })->field(['uid', 'order_id', 'real_name', 'status', 'pay_price', 'total_num', 'add_time', 'pay_time', 'paid'])->order('add_time desc')->select()->toArray(); } /** * 拼团订单统计数量 * @param $id * @param $where * @param int $page * @param int $limit * @return int * @throws \ReflectionException * @author: 吴汐 * @email: 442384644@qq.com * @date: 2023/8/31 */ public function combinationStatisticsCount($id, $where) { return $this->search($where)->where('combination_id', $id)->count(); } /** * 查找待收货的子订单 * @param int $pid * @return array * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException * @author: 吴汐 * @email: 442384644@qq.com * @date: 2023/8/31 */ public function getSubOrderNotSendList(int $pid) { return $this->getModel()->where('pid', $pid)->where('status', 1)->select()->toArray(); } /** * 判断订单是否全部发货 * @param int $pid * @param int $order_id * @return int * @author: 吴汐 * @email: 442384644@qq.com * @date: 2023/8/31 */ public function getSubOrderNotSend(int $pid, int $order_id) { return $this->getModel()->where('pid', $pid)->where('status', 0)->where('id', '<>', $order_id)->count(); } /** * 判断是否存在子未收货子订单 * @param int $pid * @param int $order_id * @return int * @author: 吴汐 * @email: 442384644@qq.com * @date: 2023/8/31 */ public function getSubOrderNotTake(int $pid, int $order_id) { return $this->getModel()->where('pid', $pid)->where('status', 1)->where('id', '<>', $order_id)->count(); } }