231 lines
10 KiB
PHP
231 lines
10 KiB
PHP
<?php
|
||
// +----------------------------------------------------------------------
|
||
// | CRMEB [ CRMEB赋能开发者，助力企业发展 ]
|
||
// +----------------------------------------------------------------------
|
||
// | Copyright (c) 2016~2020 https://www.crmeb.com All rights reserved.
|
||
// +----------------------------------------------------------------------
|
||
// | Licensed CRMEB并不是自由软件，未经许可不能去掉CRMEB相关版权
|
||
// +----------------------------------------------------------------------
|
||
// | Author: CRMEB Team <admin@crmeb.com>
|
||
// +----------------------------------------------------------------------
|
||
declare (strict_types=1);
|
||
|
||
namespace app\dao\order;
|
||
|
||
|
||
use app\dao\BaseDao;
|
||
use app\model\order\StoreOrderRefund;
|
||
|
||
/**
|
||
* 退款订单
|
||
* Class StoreOrderInvoiceDao
|
||
* @package app\dao\order
|
||
*/
|
||
class StoreOrderRefundDao extends BaseDao
|
||
{
|
||
|
||
protected function setModel(): string
|
||
{
|
||
return StoreOrderRefund::class;
|
||
}
|
||
|
||
/**
|
||
* 搜索器
|
||
* @param array $where
|
||
* @return \crmeb\basic\BaseModel|mixed|\think\Model
|
||
*/
|
||
public function search(array $where = [])
|
||
{
|
||
$realName = $where['real_name'] ?? '';
|
||
$fieldKey = $where['field_key'] ?? '';
|
||
$fieldKey = $fieldKey == 'all' ? '' : $fieldKey;
|
||
return parent::search($where)->when(isset($where['plat_type']) && in_array($where['plat_type'], [-1, 0, 1, 2]), function ($query) use ($where) {
|
||
switch ($where['plat_type']) {
|
||
case -1://所有
|
||
break;
|
||
case 0://平台
|
||
$query->where('store_id', 0)->where('supplier_id', 0);
|
||
break;
|
||
case 1://门店
|
||
$query->where('store_id', '>', 0);
|
||
break;
|
||
case 2://供应商
|
||
$query->where('supplier_id', '>', 0);
|
||
break;
|
||
}
|
||
})->when(isset($where['refund_type']) && $where['refund_type'] !== '', function ($query) use ($where) {
|
||
if ($where['refund_type'] == 0) {
|
||
$query->where('refund_type', '>=', 0);
|
||
} else {
|
||
if (is_array($where['refund_type'])) {
|
||
$query->whereIn('refund_type', $where['refund_type']);
|
||
} else {
|
||
if (in_array($where['refund_type'], [1, 2])) {
|
||
$query->where('refund_type', 0)->where('apply_type', $where['refund_type']);
|
||
} else {
|
||
$query->where('refund_type', $where['refund_type']);
|
||
}
|
||
}
|
||
}
|
||
})->when(isset($where['apply_type']) && $where['apply_type'] !== '', function ($query) use ($where) {
|
||
$query->where('apply_type', $where['apply_type']);
|
||
})->when(isset($where['order_id']) && $where['order_id'] != '', function ($query) use ($where) {
|
||
$query->where(function ($q) use ($where) {
|
||
$q->whereLike('order_id|refund_express', '%' . $where['order_id'] . '%')->whereOr(function ($q) use ($where) {
|
||
$q->whereOr('uid', 'in', function ($q) use ($where) {
|
||
$q->name('user')->whereLike('nickname|uid|phone', '%' . $where['order_id'] . '%')->field(['uid'])->select();
|
||
})->whereOr('store_order_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['order_id'] . '%')->field(['id'])->select();
|
||
})->field(['oid'])->select();
|
||
})->whereOr('store_order_id', 'in', function ($orderModel) use ($where) {
|
||
$orderModel->name('store_order')->field('id')->whereLike('order_id|uid|user_phone', '%' . $where['order_id'] . '%');
|
||
});
|
||
});
|
||
});
|
||
})->when($realName && !$fieldKey, function ($query) use ($where) {
|
||
$query->where(function ($que) use ($where) {
|
||
$que->whereLike('order_id|refund_express', '%' . $where['real_name'] . '%')->whereOr(function ($q) use ($where) {
|
||
$q->whereOr('uid', 'in', function ($q) use ($where) {
|
||
$q->name('user')->whereLike('nickname|uid|phone', '%' . $where['real_name'] . '%')->field(['uid'])->select();
|
||
})->whereOr('store_order_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();
|
||
})->whereOr('store_order_id', 'in', function ($orderModel) use ($where) {
|
||
$orderModel->name('store_order')->field('id')->whereLike('order_id', '%' . $where['real_name'] . '%');
|
||
});
|
||
});
|
||
});
|
||
})->when(isset($where['refundTypes']) && $where['refundTypes'] != '', function ($query) use ($where) {
|
||
switch ((int)$where['refundTypes']) {
|
||
case 0://未处理
|
||
$query->where('refund_type', 0);
|
||
break;
|
||
case 1://申请中
|
||
$query->whereIn('refund_type', [1, 2]);
|
||
break;
|
||
case 2://待退货
|
||
$query->whereIn('refund_type', [4, 5]);
|
||
break;
|
||
case 3://退款中
|
||
$query->where('refund_type', 5);
|
||
break;
|
||
case 4://已退款
|
||
$query->where('refund_type', 6);
|
||
break;
|
||
case 5://处理中
|
||
$query->whereIn('refund_type', [0, 1, 2, 4, 5]);
|
||
break;
|
||
case 6://已完成
|
||
$query->whereIn('refund_type', [3, 6]);
|
||
break;
|
||
}
|
||
})->when(isset($where['supplier']) && $where['supplier'] !== '', function ($query) use ($where) {
|
||
$query->where('supplier_id', '>', 0);
|
||
})->when(isset($where['store']) && $where['store'] !== '', function ($query) use ($where) {
|
||
$query->where('store_id', '>', 0);
|
||
});
|
||
}
|
||
|
||
/**
|
||
* 查询退款订单
|
||
* @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 getRefundList($where, string $file = '*', array $with = [], int $page = 0, int $limit = 0)
|
||
{
|
||
return $this->search($where)->field($file)->with(array_merge(['user'], $with))
|
||
->when($page != 0 && $limit != 0, function ($query) use ($page, $limit) {
|
||
$query->page($page, $limit);
|
||
})->order('add_time desc')->select()->toArray();
|
||
}
|
||
|
||
/**
|
||
* 获取退款金额按照时间分组
|
||
* @param array $time
|
||
* @param string $timeType
|
||
* @param string $field
|
||
* @param string $str
|
||
* @return mixed
|
||
*/
|
||
public function getUserRefundPriceList(array $time, string $timeType, string $str, string $field = 'add_time')
|
||
{
|
||
return $this->getModel()->where('is_cancel', 0)->where(function ($query) use ($time, $field) {
|
||
if ($time[0] == $time[1]) {
|
||
$query->whereDay($field, $time[0]);
|
||
} else {
|
||
$time[1] = date('Y/m/d', strtotime($time[1]) + 86400);
|
||
$query->whereTime($field, 'between', $time);
|
||
}
|
||
})->field("FROM_UNIXTIME($field,'$timeType') as days,$str as num,GROUP_CONCAT(store_order_id) as link_ids")->group('days')->select()->toArray();
|
||
}
|
||
|
||
/**
|
||
* 根据时间获取
|
||
* @param array $where
|
||
* @return float|int
|
||
*/
|
||
public function getOrderRefundMoneyByWhere(array $where, string $sum_field, string $selectType, string $group = "")
|
||
{
|
||
|
||
switch ($selectType) {
|
||
case "sum" :
|
||
return $this->getDayTotalMoney($where, $sum_field);
|
||
case "group" :
|
||
return $this->getDayGroupMoney($where, $sum_field, $group);
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 按照支付时间统计支付金额
|
||
* @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('add_time', $where['timeKey']['start_time'], $where['timeKey']['end_time']);
|
||
})
|
||
->sum($sumField);
|
||
}
|
||
|
||
|
||
/**
|
||
* 时间分组订单付款金额统计
|
||
* @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('add_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 = "%Y-%m";
|
||
}
|
||
$query->field("sum($sumField) as number,FROM_UNIXTIME($group, '$timeUinx') as time");
|
||
$query->group("FROM_UNIXTIME($group, '$timeUinx')");
|
||
})
|
||
->order('add_time ASC')->select()->toArray();
|
||
}
|
||
}
|