* @day: 2017/11/11
*/
namespace app\admin\model\order;
use crmeb\basic\BaseModel;
use crmeb\traits\ModelTrait;
use think\facade\Route as Url;
use app\models\store\StoreCart;
use app\admin\model\wechat\WechatUser;
use app\admin\model\store\StoreProduct;
use app\models\routine\RoutineTemplate;
use app\admin\model\user\{User, UserBill};
use app\admin\model\ump\{StoreCouponUser, StorePink};
use crmeb\services\{PHPExcelService, WechatService, WechatTemplateService};
/**
* 订单管理Model
* Class StoreOrder
* @package app\admin\model\store
*/
class StoreOrder extends BaseModel
{
/**
* 数据表主键
* @var string
*/
protected $pk = 'id';
/**
* 模型名称
* @var string
*/
protected $name = 'store_order';
use ModelTrait;
public static function orderCount()
{
$data['ys'] = self::statusByWhere(9, new self())->where(['is_system_del' => 0])->count();
$data['wz'] = self::statusByWhere(0, new self())->where(['is_system_del' => 0])->count();
$data['wf'] = self::statusByWhere(1, new self())->where(['is_system_del' => 0, 'shipping_type' => 1])->count();
$data['ds'] = self::statusByWhere(2, new self())->where(['is_system_del' => 0, 'shipping_type' => 1])->count();
$data['dp'] = self::statusByWhere(3, new self())->where(['is_system_del' => 0])->count();
$data['jy'] = self::statusByWhere(4, new self())->where(['is_system_del' => 0])->count();
$data['tk'] = self::statusByWhere(-1, new self())->where(['is_system_del' => 0])->count();
$data['yt'] = self::statusByWhere(-2, new self())->where(['is_system_del' => 0])->count();
$data['del'] = self::statusByWhere(-4, new self())->where(['is_system_del' => 0])->count();
$data['write_off'] = self::statusByWhere(5, new self())->where(['is_system_del' => 0])->count();
$data['general'] = self::where(['pink_id' => 0, 'combination_id' => 0, 'seckill_id' => 0, 'bargain_id' => 0, 'is_system_del' => 0])->count();
$data['pink'] = self::where('pink_id|combination_id', '>', 0)->where('is_system_del', 0)->count();
$data['seckill'] = self::where('seckill_id', '>', 0)->where('is_system_del', 0)->count();
$data['bargain'] = self::where('bargain_id', '>', 0)->where('is_system_del', 0)->count();
return $data;
}
public static function OrderList($where)
{
$model = self::getOrderWhere($where, self::alias('a')
->join('user r', 'r.uid=a.uid', 'LEFT'), 'a.', 'r')
->field('a.*,r.nickname,r.phone,r.spread_uid');
if ($where['order'] != '') {
$model = $model->order(self::setOrder($where['order']));
} else {
$model = $model->order('a.id desc');
}
if (isset($where['excel']) && $where['excel'] == 1) {
$data = ($data = $model->select()) && count($data) ? $data->toArray() : [];
} else {
$data = ($data = $model->page((int)$where['page'], (int)$where['limit'])->select()) && count($data) ? $data->toArray() : [];
}
foreach ($data as &$item) {
$_info = StoreOrderCartInfo::where('oid', $item['id'])->field('cart_info')->select();
$_info = count($_info) ? $_info->toArray() : [];
foreach ($_info as $k => $v) {
$cart_info = json_decode($v['cart_info'], true);
if (!isset($cart_info['productInfo'])) $cart_info['productInfo'] = [];
$_info[$k]['cart_info'] = $cart_info;
unset($cart_info);
}
$item['_info'] = $_info;
$item['spread_nickname'] = User::where('uid', $item['spread_uid'])->value('nickname');
$item['add_time'] = $item['add_time'] ? date('Y-m-d H:i:s', $item['add_time']) : '';
$item['back_integral'] = $item['back_integral'] ?: 0;
if ($item['pink_id'] || $item['combination_id']) {
$pinkStatus = StorePink::where('order_id_key', $item['id'])->value('status');
switch ($pinkStatus) {
case 1:
$item['pink_name'] = '[拼团订单]正在进行中';
$item['color'] = '#f00';
break;
case 2:
$item['pink_name'] = '[拼团订单]已完成';
$item['color'] = '#00f';
break;
case 3:
$item['pink_name'] = '[拼团订单]未完成';
$item['color'] = '#f0f';
break;
default:
$item['pink_name'] = '[拼团订单]历史订单';
$item['color'] = '#457856';
break;
}
} elseif ($item['seckill_id']) {
$item['pink_name'] = '[秒杀订单]';
$item['color'] = '#32c5e9';
} elseif ($item['bargain_id']) {
$item['pink_name'] = '[砍价订单]';
$item['color'] = '#12c5e9';
} else {
if ($item['shipping_type'] == 1) {
$item['pink_name'] = '[普通订单]';
$item['color'] = '#895612';
} else if ($item['shipping_type'] == 2) {
$item['pink_name'] = '[核销订单]';
$item['color'] = '#8956E8';
}
}
if ($item['paid'] == 1) {
switch ($item['pay_type']) {
case 'weixin':
$item['pay_type_name'] = '微信支付';
break;
case 'yue':
$item['pay_type_name'] = '余额支付';
break;
case 'ali':
$item['pay_type_name'] = '支付宝支付';
break;
case 'offline':
$item['pay_type_name'] = '线下支付';
break;
default:
$item['pay_type_name'] = '其他支付';
break;
}
} else {
switch ($item['pay_type']) {
default:
$item['pay_type_name'] = '未支付';
break;
case 'offline':
$item['pay_type_name'] = '线下支付';
$item['pay_type_info'] = 1;
break;
}
}
if ($item['paid'] == 0 && $item['status'] == 0) {
$item['status_name'] = '未支付';
} else if ($item['paid'] == 1 && $item['status'] == 0 && $item['shipping_type'] == 1 && $item['refund_status'] == 0) {
$item['status_name'] = '未发货';
} else if ($item['paid'] == 1 && $item['status'] == 0 && $item['shipping_type'] == 2 && $item['refund_status'] == 0) {
$item['status_name'] = '未核销';
} else if ($item['paid'] == 1 && $item['status'] == 1 && $item['shipping_type'] == 1 && $item['refund_status'] == 0) {
$item['status_name'] = '待收货';
} else if ($item['paid'] == 1 && $item['status'] == 1 && $item['shipping_type'] == 2 && $item['refund_status'] == 0) {
$item['status_name'] = '未核销';
} else if ($item['paid'] == 1 && $item['status'] == 2 && $item['refund_status'] == 0) {
$item['status_name'] = '待评价';
} else if ($item['paid'] == 1 && $item['status'] == 3 && $item['refund_status'] == 0) {
$item['status_name'] = '已完成';
} else if ($item['paid'] == 1 && $item['refund_status'] == 1) {
$refundReasonTime = date('Y-m-d H:i', $item['refund_reason_time']);
$refundReasonWapImg = json_decode($item['refund_reason_wap_img'], true);
$refundReasonWapImg = $refundReasonWapImg ? $refundReasonWapImg : [];
$img = '';
if (count($refundReasonWapImg)) {
foreach ($refundReasonWapImg as $itemImg) {
if (strlen(trim($itemImg)))
$img .= '
';
}
}
if (!strlen(trim($img))) $img = '无';
if (isset($where['excel']) && $where['excel'] == 1) {
$refundImageStr = implode(',', $refundReasonWapImg);
$item['status_name'] = <<申请退款
退款原因：{$item['refund_reason_wap']}
备注说明：{$item['refund_reason_wap_explain']}
退款时间：{$refundReasonTime}
退款凭证：{$img}
HTML;
}
} else if ($item['paid'] == 1 && $item['refund_status'] == 2) {
$item['status_name'] = '已退款';
}
if ($item['paid'] == 1 && $item['status'] == 0 && $item['shipping_type'] == 2) {
$item['_status'] = 0;
} else if ($item['paid'] == 0 && $item['status'] == 0 && $item['refund_status'] == 0) {
$item['_status'] = 1;
} else if ($item['paid'] == 1 && $item['status'] == 0 && $item['refund_status'] == 0) {
$item['_status'] = 2;
} else if ($item['paid'] == 1 && $item['refund_status'] == 1) {
$item['_status'] = 3;
} else if ($item['paid'] == 1 && $item['status'] == 1 && $item['refund_status'] == 0) {
$item['_status'] = 4;
} else if ($item['paid'] == 1 && $item['status'] == 2 && $item['refund_status'] == 0) {
$item['_status'] = 5;
} else if ($item['paid'] == 1 && $item['status'] == 3 && $item['refund_status'] == 0) {
$item['_status'] = 6;
} else if ($item['paid'] == 1 && $item['refund_status'] == 2) {
$item['_status'] = 7;
}
}
if (isset($where['excel']) && $where['excel'] == 1) {
self::SaveExcel($data);
}
$count = self::getOrderWhere($where, self::alias('a')->join('user r', 'r.uid=a.uid', 'LEFT'), 'a.', 'r')->count();
return compact('count', 'data');
}
/*
* 保存并下载excel
* $list array
* return
*/
public static function SaveExcel($list)
{
$export = [];
foreach ($list as $index => $item) {
$_info = StoreOrderCartInfo::where('oid', $item['id'])->column('cart_info');
$goodsName = [];
foreach ($_info as $k => $v) {
$v = json_decode($v, true);
$suk = '';
if (isset($v['productInfo']['attrInfo'])) {
if (isset($v['productInfo']['attrInfo']['suk'])) {
$suk = '(' . $v['productInfo']['attrInfo']['suk'] . ')';
}
}
$goodsName[] = implode(
[$v['productInfo']['store_name'],
$suk,
"[{$v['cart_num']} * {$v['truePrice']}]"
], ' ');
}
$item['cartInfo'] = $_info;
$sex = WechatUser::where('uid', $item['uid'])->value('sex');
if ($sex == 1) $sex_name = '男';
else if ($sex == 2) $sex_name = '女';
else $sex_name = '未知';
$export[] = [
$item['order_id'],
$sex_name,
$item['phone'],
$item['real_name'],
$item['user_phone'],
$item['user_address'],
$goodsName,
$item['total_price'],
$item['pay_price'],
$item['pay_postage'],
$item['coupon_price'],
$item['pay_type_name'],
$item['pay_time'] > 0 ? date('Y/m-d H:i', $item['pay_time']) : '暂无',
$item['status_name'],
$item['add_time'],
$item['mark']
];
}
PHPExcelService::setExcelHeader(['订单号', '性别', '电话', '收货人姓名', '收货人电话', '收货地址', '商品信息',
'总价格', '实际支付', '邮费', '优惠金额', '支付状态', '支付时间', '订单状态', '下单时间', '用户备注'])
->setExcelTile('订单导出' . date('YmdHis', time()), '订单信息' . time(), ' 生成时间：' . date('Y-m-d H:i:s', time()))
->setExcelContent($export)
->ExcelSave();
}
/**
* @param $where
* @return array
*/
public static function systemPage($where, $userid = false)
{
$model = self::getOrderWhere($where, self::alias('a')
->join('user r', 'r.uid=a.uid', 'LEFT'), 'a.', 'r')
->field('a.*,r.nickname');
if ($where['order']) {
$model = $model->order('a.' . $where['order']);
} else {
$model = $model->order('a.id desc');
}
if ($where['export'] == 1) {
$list = $model->select()->toArray();
$export = [];
foreach ($list as $index => $item) {
if ($item['pay_type'] == 'weixin') {
$payType = '微信支付';
} elseif ($item['pay_type'] == 'yue') {
$payType = '余额支付';
} elseif ($item['pay_type'] == 'offline') {
$payType = '线下支付';
} else {
$payType = '其他支付';
}
$_info = StoreOrderCartInfo::where('oid', $item['id'])->column('cart_info', 'oid');
$goodsName = [];
foreach ($_info as $k => $v) {
$v = json_decode($v, true);
$goodsName[] = implode(
[$v['productInfo']['store_name'],
isset($v['productInfo']['attrInfo']) ? '(' . $v['productInfo']['attrInfo']['suk'] . ')' : '',
"[{$v['cart_num']} * {$v['truePrice']}]"
], ' ');
}
$item['cartInfo'] = $_info;
$export[] = [
$item['order_id'], $payType,
$item['total_num'], $item['total_price'], $item['total_postage'], $item['pay_price'], $item['refund_price'],
$item['mark'], $item['remark'],
[$item['real_name'], $item['user_phone'], $item['user_address']],
$goodsName,
[$item['paid'] == 1 ? '已支付' : '未支付', '支付时间: ' . ($item['pay_time'] > 0 ? date('Y/md H:i', $item['pay_time']) : '暂无')]
];
$list[$index] = $item;
}
PHPExcelService::setExcelHeader(['订单号', '支付方式', '商品总数', '商品总价', '邮费', '支付金额', '退款金额', '用户备注', '管理员备注', '收货人信息', '商品信息', '支付状态'])
->setExcelTile('订单导出', '订单信息' . time(), ' 生成时间：' . date('Y-m-d H:i:s', time()))
->setExcelContent($export)
->ExcelSave();
}
return self::page($model, function ($item) {
$_info = StoreOrderCartInfo::where('oid', $item['id'])->field('cart_info')->select();
foreach ($_info as $k => $v) {
$_info[$k]['cart_info'] = json_decode($v['cart_info'], true);
}
$item['_info'] = $_info;
if ($item['pink_id'] && $item['combination_id']) {
$pinkStatus = StorePink::where('order_id_key', $item['id'])->value('status');
switch ($pinkStatus) {
case 1:
$item['pink_name'] = '[拼团订单]正在进行中';
$item['color'] = '#f00';
break;
case 2:
$item['pink_name'] = '[拼团订单]已完成';
$item['color'] = '#00f';
break;
case 3:
$item['pink_name'] = '[拼团订单]未完成';
$item['color'] = '#f0f';
break;
default:
$item['pink_name'] = '[拼团订单]历史订单';
$item['color'] = '#457856';
break;
}
} else {
if ($item['seckill_id']) {
$item['pink_name'] = '[秒杀订单]';
$item['color'] = '#32c5e9';
} elseif ($item['bargain_id']) {
$item['pink_name'] = '[砍价订单]';
$item['color'] = '#12c5e9';
} else {
$item['pink_name'] = '[普通订单]';
$item['color'] = '#895612';
}
}
}, $where);
}
public static function statusByWhere($status, $model = null, $alert = '')
{
if ($model == null) $model = new self;
if ('' === $status)
return $model;
else if ($status == 8)
return $model;
else if ($status == 0)//未支付
return $model->where($alert . 'paid', 0)->where($alert . 'status', 0)->where($alert . 'refund_status', 0)->where($alert . 'is_del', 0);
else if ($status == 1)//已支付 未发货
return $model->where($alert . 'paid', 1)->where($alert . 'status', 0)->where($alert . 'shipping_type', 1)->where($alert . 'refund_status', 0)->where($alert . 'is_del', 0);
else if ($status == 2)//已支付 待收货
return $model->where($alert . 'paid', 1)->where($alert . 'status', 1)->where($alert . 'shipping_type', 1)->where($alert . 'refund_status', 0)->where($alert . 'is_del', 0);
else if ($status == 5)//已支付 待核销
return $model->where($alert . 'paid', 1)->where($alert . 'status', 0)->where($alert . 'shipping_type', 2)->where($alert . 'refund_status', 0)->where($alert . 'is_del', 0);
else if ($status == 3)// 已支付 已收货 待评价
return $model->where($alert . 'paid', 1)->where($alert . 'status', 2)->where($alert . 'refund_status', 0)->where($alert . 'is_del', 0);
else if ($status == 4)// 交易完成
return $model->where($alert . 'paid', 1)->where($alert . 'status', 3)->where($alert . 'refund_status', 0)->where($alert . 'is_del', 0);
else if ($status == -1)//退款中
return $model->where($alert . 'paid', 1)->where($alert . 'refund_status', 1)->where($alert . 'is_del', 0);
else if ($status == -2)//已退款
return $model->where($alert . 'paid', 1)->where($alert . 'refund_status', 2)->where($alert . 'is_del', 0);
else if ($status == -3)//退款
return $model->where($alert . 'paid', 1)->where($alert . 'refund_status', 'in', '1,2')->where($alert . 'is_del', 0);
else if ($status == -4)//已删除
return $model->where($alert . 'is_del', 1);
else if ($status == 9)//已卖出
return $model->where($alert . 'paid', 1)->where($alert . 'refund_status', 0)->where($alert . 'is_del', 0);
else
return $model;
}
public static function timeQuantumWhere($startTime = null, $endTime = null, $model = null)
{
if ($model === null) $model = new self;
if ($startTime != null && $endTime != null)
$model = $model->where('add_time', '>', strtotime($startTime))->where('add_time', '<', strtotime($endTime));
return $model;
}
public static function changeOrderId($orderId)
{
$ymd = substr($orderId, 2, 8);
$key = substr($orderId, 16);
return 'wx' . $ymd . date('His') . $key;
}
/**
* 线下付款
* @param $id
* @return $this
*/
public static function updateOffline($id)
{
$count = self::where('id', $id)->count();
if (!$count) return self::setErrorInfo('订单不存在');
$count = self::where('id', $id)->where('paid', 0)->count();
if (!$count) return self::setErrorInfo('订单已支付');
$res = self::where('id', $id)->update(['paid' => 1, 'pay_time' => time()]);
return $res;
}
/**
* TODO 公众号退款发送模板消息
* @param $oid
* $oid 订单id key
*/
public static function refundTemplate($data, $oid)
{
$order = self::where('id', $oid)->find();
WechatTemplateService::sendTemplate(WechatUser::where('uid', $order['uid'])->value('openid'), WechatTemplateService::ORDER_REFUND_STATUS, [
'first' => '亲，您购买的商品已退款,本次退款' . $data['refund_price'] . '金额',
'keyword1' => $order['order_id'],
'keyword2' => $order['pay_price'],
'keyword3' => date('Y-m-d H:i:s', $order['add_time']),
'remark' => '点击查看订单详情'
], Url::buildUrl('/order/detail/' . $order['order_id'])->suffix('')->domain(true)->build());
}
/**
* TODO 小程序余额退款模板消息
* @param $oid
* @return bool|mixed
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\ModelNotFoundException
* @throws \think\exception\DbException
*/
public static function refundRoutineTemplate($oid)
{
$order = self::where('id', $oid)->find();
return RoutineTemplate::sendOrderRefundSuccess($order);
}
/**
* 处理where条件
* @param $where
* @param $model
* @return mixed
*/
public static function getOrderWhere($where, $model, $aler = '', $join = '')
{
// $model = $model->where('combination_id',0);
$model = $model->where('is_system_del', 0);
if (isset($where['status']) && $where['status'] != '') {
$model = self::statusByWhere($where['status'], $model, $aler);
}
if (isset($where['is_del']) && $where['is_del'] != '' && $where['is_del'] != -1) $model = $model->where($aler . 'is_del', $where['is_del']);
if (isset($where['combination_id'])) {
if ($where['combination_id'] == '普通订单') {
$model = $model->where($aler . 'combination_id', 0)->where($aler . 'seckill_id', 0)->where($aler . 'bargain_id', 0);
}
if ($where['combination_id'] == '拼团订单') {
$model = $model->where($aler . 'combination_id', ">", 0)->where($aler . 'pink_id', ">", 0);
}
if ($where['combination_id'] == '秒杀订单') {
$model = $model->where($aler . 'seckill_id', ">", 0);
}
if ($where['combination_id'] == '砍价订单') {
$model = $model->where($aler . 'bargain_id', ">", 0);
}
}
if (isset($where['pay_type'])) {
switch ($where['pay_type']) {
case 1:
$model = $model->where($aler . 'pay_type', 'weixin');
break;
case 2:
$model = $model->where($aler . 'pay_type', 'yue');
break;
case 3:
$model = $model->where($aler . 'pay_type', 'offline');
break;
}
}
if (isset($where['type'])) {
switch ($where['type']) {
case 1:
$model = $model->where($aler . 'combination_id', 0)->where($aler . 'seckill_id', 0)->where($aler . 'bargain_id', 0);
break;
case 2:
// $model = $model->where($aler.'combination_id',">",0)->where($aler.'pink_id',">",0);
$model = $model->where($aler . 'combination_id', ">", 0);
break;
case 3:
$model = $model->where($aler . 'seckill_id', ">", 0);
break;
case 4:
$model = $model->where($aler . 'bargain_id', ">", 0);
break;
}
}
if (isset($where['real_name']) && $where['real_name'] != '') {
$model = $model->where($aler . 'order_id|' . $aler . 'real_name|' . $aler . 'user_phone' . ($join ? '|' . $join . '.nickname|' . $join . '.uid|' . $join . '.phone' : ''), 'LIKE', "%$where[real_name]%");
}
if (isset($where['data']) && $where['data'] !== '') {
$model = self::getModelTime($where, $model, $aler . 'add_time');
}
return $model;
}
public static function getBadge($where)
{
$price = self::getOrderPrice($where);
return [
[
'name' => '订单数量',
'field' => '件',
'count' => $price['count_sum'],
'background_color' => 'layui-bg-blue',
'col' => 2
],
[
'name' => '售出商品',
'field' => '件',
'count' => $price['total_num'],
'background_color' => 'layui-bg-blue',
'col' => 2
],
[
'name' => '订单金额',
'field' => '元',
'count' => $price['pay_price'],
'background_color' => 'layui-bg-blue',
'col' => 2
],
[
'name' => '退款金额',
'field' => '元',
'count' => $price['refund_price'],
'background_color' => 'layui-bg-blue',
'col' => 2
],
[
'name' => '微信支付金额',
'field' => '元',
'count' => $price['pay_price_wx'],
'background_color' => 'layui-bg-blue',
'col' => 2
],
[
'name' => '余额支付金额',
'field' => '元',
'count' => $price['pay_price_yue'],
'background_color' => 'layui-bg-blue',
'col' => 2
],
[
'name' => '运费金额',
'field' => '元',
'count' => $price['pay_postage'],
'background_color' => 'layui-bg-blue',
'col' => 2
],
[
'name' => '分佣金额',
'field' => '元',
'count' => $price['brokerage'],
'background_color' => 'layui-bg-blue',
'col' => 2
],
[
'name' => '线下支付金额',
'field' => '元',
'count' => $price['pay_price_offline'],
'background_color' => 'layui-bg-blue',
'col' => 2
],
[
'name' => '积分抵扣',
'field' => '分',
'count' => $price['use_integral'] . '(抵扣金额:￥' . $price['deduction_price'] . ')',
'background_color' => 'layui-bg-blue',
'col' => 2
],
[
'name' => '退回积分',
'field' => '元',
'count' => $price['back_integral'],
'background_color' => 'layui-bg-blue',
'col' => 2
]
];
}
/**
* 处理订单金额
* @param $where
* @return array
*/
public static function getOrderPrice($where)
{
$where['is_del'] = 0;//删除订单不统计
$model = new self;
$price = [];
$price['pay_price'] = 0;//支付金额
$price['refund_price'] = 0;//退款金额
$price['pay_price_wx'] = 0;//微信支付金额
$price['pay_price_yue'] = 0;//余额支付金额
$price['pay_price_offline'] = 0;//线下支付金额
$price['pay_price_other'] = 0;//其他支付金额
$price['use_integral'] = 0;//用户使用积分
$price['back_integral'] = 0;//退积分总数
$price['deduction_price'] = 0;//抵扣金额
$price['total_num'] = 0; //商品总数
$price['count_sum'] = 0; //商品总数
$price['brokerage'] = 0;
$price['pay_postage'] = 0;
$whereData = ['is_del' => 0];
if ($where['status'] == '') {
$whereData['paid'] = 1;
$whereData['refund_status'] = 0;
}
$ids = self::getOrderWhere($where, $model)->where($whereData)->column('id');
if (count($ids)) {
$price['brokerage'] = UserBill::where(['category' => 'now_money', 'type' => 'brokerage'])->where('link_id', 'in', $ids)->sum('number');
}
$price['refund_price'] = self::getOrderWhere($where, $model)->where(['is_del' => 0, 'paid' => 1, 'refund_status' => 2])->sum('refund_price');
$sumNumber = self::getOrderWhere($where, $model)->where($whereData)->field([
'sum(total_num) as sum_total_num',
'count(id) as count_sum',
'sum(pay_price) as sum_pay_price',
'sum(pay_postage) as sum_pay_postage',
'sum(use_integral) as sum_use_integral',
'sum(back_integral) as sum_back_integral',
'sum(deduction_price) as sum_deduction_price'
])->find();
if ($sumNumber) {
$price['count_sum'] = $sumNumber['count_sum'];
$price['total_num'] = $sumNumber['sum_total_num'];
$price['pay_price'] = $sumNumber['sum_pay_price'];
$price['pay_postage'] = $sumNumber['sum_pay_postage'];
$price['use_integral'] = $sumNumber['sum_use_integral'];
$price['back_integral'] = $sumNumber['sum_back_integral'];
$price['deduction_price'] = $sumNumber['sum_deduction_price'];
}
$list = self::getOrderWhere($where, $model)->where($whereData)->group('pay_type')->column('sum(pay_price) as sum_pay_price,pay_type', 'id');
foreach ($list as $v) {
if ($v['pay_type'] == 'weixin') {
$price['pay_price_wx'] = $v['sum_pay_price'];
} elseif ($v['pay_type'] == 'yue') {
$price['pay_price_yue'] = $v['sum_pay_price'];
} elseif ($v['pay_type'] == 'offline') {
$price['pay_price_offline'] = $v['sum_pay_price'];
} else {
$price['pay_price_other'] = $v['sum_pay_price'];
}
}
return $price;
}
public static function systemPagePink($where)
{
$model = new self;
$model = self::getOrderWherePink($where, $model);
$model = $model->order('id desc');
if ($where['export'] == 1) {
$list = $model->select()->toArray();
$export = [];
foreach ($list as $index => $item) {
if ($item['pay_type'] == 'weixin') {
$payType = '微信支付';
} elseif ($item['pay_type'] == 'yue') {
$payType = '余额支付';
} elseif ($item['pay_type'] == 'offline') {
$payType = '线下支付';
} else {
$payType = '其他支付';
}
$_info = StoreOrderCartInfo::where('oid', $item['id'])->column('cart_info', 'oid');
$goodsName = [];
foreach ($_info as $k => $v) {
$v = json_decode($v, true);
$goodsName[] = implode(
[$v['productInfo']['store_name'],
isset($v['productInfo']['attrInfo']) ? '(' . $v['productInfo']['attrInfo']['suk'] . ')' : '',
"[{$v['cart_num']} * {$v['truePrice']}]"
], ' ');
}
$item['cartInfo'] = $_info;
$export[] = [
$item['order_id'], $payType,
$item['total_num'], $item['total_price'], $item['total_postage'], $item['pay_price'], $item['refund_price'],
$item['mark'], $item['remark'],
[$item['real_name'], $item['user_phone'], $item['user_address']],
$goodsName,
[$item['paid'] == 1 ? '已支付' : '未支付', '支付时间: ' . ($item['pay_time'] > 0 ? date('Y/md H:i', $item['pay_time']) : '暂无')]
];
$list[$index] = $item;
}
ExportService::exportCsv($export, '订单导出' . time(), ['订单号', '支付方式', '商品总数', '商品总价', '邮费', '支付金额', '退款金额', '用户备注', '管理员备注', '收货人信息', '商品信息', '支付状态']);
}
return self::page($model, function ($item) {
$item['nickname'] = WechatUser::where('uid', $item['uid'])->value('nickname');
$_info = StoreOrderCartInfo::where('oid', $item['id'])->field('cart_info')->select();
foreach ($_info as $k => $v) {
$_info[$k]['cart_info'] = json_decode($v['cart_info'], true);
}
$item['_info'] = $_info;
}, $where);
}
/**
* 处理where条件
* @param $where
* @param $model
* @return mixed
*/
public static function getOrderWherePink($where, $model)
{
$model = $model->where('combination_id', '>', 0);
if ($where['status'] != '') $model = $model::statusByWhere($where['status']);
// if($where['is_del'] != '' && $where['is_del'] != -1) $model = $model->where('is_del',$where['is_del']);
if ($where['real_name'] != '') {
$model = $model->where('order_id|real_name|user_phone', 'LIKE', "%$where[real_name]%");
}
if ($where['data'] !== '') {
$model = self::getModelTime($where, $model, 'add_time');
}
return $model;
}
/**
* 处理订单金额
* @param $where
* @return array
*/
public static function getOrderPricePink($where)
{
$model = new self;
$price = [];
$price['pay_price'] = 0;//支付金额
$price['refund_price'] = 0;//退款金额
$price['pay_price_wx'] = 0;//微信支付金额
$price['pay_price_yue'] = 0;//余额支付金额
$price['pay_price_offline'] = 0;//线下支付金额
$price['pay_price_other'] = 0;//其他支付金额
$price['use_integral'] = 0;//用户使用积分
$price['back_integral'] = 0;//退积分总数
$price['deduction_price'] = 0;//抵扣金额
$price['total_num'] = 0; //商品总数
$model = self::getOrderWherePink($where, $model);
$list = $model->select()->toArray();
foreach ($list as $v) {
$price['total_num'] = bcadd($price['total_num'], $v['total_num'], 0);
$price['pay_price'] = bcadd($price['pay_price'], $v['pay_price'], 2);
$price['refund_price'] = bcadd($price['refund_price'], $v['refund_price'], 2);
$price['use_integral'] = bcadd($price['use_integral'], $v['use_integral'], 2);
$price['back_integral'] = bcadd($price['back_integral'], $v['back_integral'], 2);
$price['deduction_price'] = bcadd($price['deduction_price'], $v['deduction_price'], 2);
if ($v['pay_type'] == 'weixin') {
$price['pay_price_wx'] = bcadd($price['pay_price_wx'], $v['pay_price'], 2);
} elseif ($v['pay_type'] == 'yue') {
$price['pay_price_yue'] = bcadd($price['pay_price_yue'], $v['pay_price'], 2);
} elseif ($v['pay_type'] == 'offline') {
$price['pay_price_offline'] = bcadd($price['pay_price_offline'], $v['pay_price'], 2);
} else {
$price['pay_price_other'] = bcadd($price['pay_price_other'], $v['pay_price'], 2);
}
}
return $price;
}
/**
* 获取昨天的订单 首页在使用
* @param int $preDay
* @param int $day
* @return $this|StoreOrder
*/
public static function isMainYesterdayCount($preDay = 0, $day = 0)
{
$model = new self();
$model = $model->where('add_time', '>', $preDay);
$model = $model->where('add_time', '<', $day);
return $model;
}
/**
* 获取用户购买次数
* @param int $uid
* @return int|string
*/
public static function getUserCountPay($uid = 0)
{
if (!$uid) return 0;
return self::where('uid', $uid)->where('paid', 1)->count();
}
/**
* 获取单个用户购买列表
* @param array $where
* @return array
*/
public static function getOneorderList($where)
{
return self::where('uid', $where['uid'])
->order('add_time desc')
->page((int)$where['page'], (int)$where['limit'])
->field(['order_id,real_name,total_num,total_price,pay_price,FROM_UNIXTIME(pay_time,"%Y-%m-%d") as pay_time,paid,pay_type,pink_id,seckill_id,bargain_id'
])->select()
->toArray();
}
/**
* 设置订单统计图搜索
* @param array $where 条件
* @param null $status
* @param null $time
* @return array
*/
public static function setEchatWhere($where, $status = null, $time = null)
{
$model = self::statusByWhere($where['status'])->where('is_system_del', 0);
if ($status !== null) $where['type'] = $status;
if ($time === true) $where['data'] = '';
switch ($where['type']) {
case 1:
//普通商品
$model = $model->where('combination_id', 0)->where('seckill_id', 0)->where('bargain_id', 0);
break;
case 2:
//拼团商品
$model = $model->where('combination_id', ">", 0)->where('pink_id', ">", 0);
break;
case 3:
//秒杀商品
$model = $model->where('seckill_id', ">", 0);
break;
case 4:
//砍价商品
$model = $model->where('bargain_id', '>', 0);
break;
}
return self::getModelTime($where, $model);
}
/*
* 获取订单数据统计图
* $where array
* $limit int
* return array
*/
public static function getEchartsOrder($where, $limit = 20)
{
$orderlist = self::setEchatWhere($where)->field(
'FROM_UNIXTIME(add_time,"%Y-%m-%d") as _add_time,sum(total_num) total_num,count(*) count,sum(total_price) total_price,sum(refund_price) refund_price,group_concat(cart_id SEPARATOR "|") cart_ids'
)->group('_add_time')->order('_add_time asc')->select();
count($orderlist) && $orderlist = $orderlist->toArray();
$legend = ['商品数量', '订单数量', '订单金额', '退款金额'];
$seriesdata = [
[
'name' => $legend[0],
'type' => 'line',
'data' => [],
],
[
'name' => $legend[1],
'type' => 'line',
'data' => []
],
[
'name' => $legend[2],
'type' => 'line',
'data' => []
],
[
'name' => $legend[3],
'type' => 'line',
'data' => []
]
];
$xdata = [];
$zoom = '';
foreach ($orderlist as $item) {
$xdata[] = $item['_add_time'];
$seriesdata[0]['data'][] = $item['total_num'];
$seriesdata[1]['data'][] = $item['count'];
$seriesdata[2]['data'][] = $item['total_price'];
$seriesdata[3]['data'][] = $item['refund_price'];
}
count($xdata) > $limit && $zoom = $xdata[$limit - 5];
$badge = self::getOrderBadge($where);
$bingpaytype = self::setEchatWhere($where)->group('pay_type')->field('count(*) as count,pay_type')->select();
count($bingpaytype) && $bingpaytype = $bingpaytype->toArray();
$bing_xdata = ['微信支付', '余额支付', '其他支付'];
$color = ['#ffcccc', '#99cc00', '#fd99cc', '#669966'];
$bing_data = [];
foreach ($bingpaytype as $key => $item) {
if ($item['pay_type'] == 'weixin') {
$value['name'] = $bing_xdata[0];
} else if ($item['pay_type'] == 'yue') {
$value['name'] = $bing_xdata[1];
} else {
$value['name'] = $bing_xdata[2];
}
$value['value'] = $item['count'];
$value['itemStyle']['color'] = isset($color[$key]) ? $color[$key] : $color[0];
$bing_data[] = $value;
}
return compact('zoom', 'xdata', 'seriesdata', 'badge', 'legend', 'bing_data', 'bing_xdata');
}
public static function getOrderBadge($where)
{
return [
[
'name' => '拼团订单数量',
'field' => '个',
'count' => self::setEchatWhere($where, 2)->count(),
'content' => '拼团总订单数量',
'background_color' => 'layui-bg-cyan',
'sum' => self::setEchatWhere($where, 2, true)->count(),
'class' => 'fa fa-line-chart',
'col' => 2
],
[
'name' => '砍价订单数量',
'field' => '个',
'count' => self::setEchatWhere($where, 4)->count(),
'content' => '砍价总订单数量',
'background_color' => 'layui-bg-cyan',
'sum' => self::setEchatWhere($where, 4, true)->count(),
'class' => 'fa fa-line-chart',
'col' => 2
],
[
'name' => '秒杀订单数量',
'field' => '个',
'count' => self::setEchatWhere($where, 3)->count(),
'content' => '秒杀总订单数量',
'background_color' => 'layui-bg-cyan',
'sum' => self::setEchatWhere($where, 3, true)->count(),
'class' => 'fa fa-line-chart',
'col' => 2
],
[
'name' => '普通订单数量',
'field' => '个',
'count' => self::setEchatWhere($where, 1)->count(),
'content' => '普通总订单数量',
'background_color' => 'layui-bg-cyan',
'sum' => self::setEchatWhere($where, 1, true)->count(),
'class' => 'fa fa-line-chart',
'col' => 2,
],
[
'name' => '使用优惠卷金额',
'field' => '元',
'count' => self::setEchatWhere($where)->sum('coupon_price'),
'content' => '普通总订单数量',
'background_color' => 'layui-bg-cyan',
'sum' => self::setEchatWhere($where, null, true)->sum('coupon_price'),
'class' => 'fa fa-line-chart',
'col' => 2
],
[
'name' => '积分消耗数',
'field' => '个',
'count' => self::setEchatWhere($where)->sum('use_integral'),
'content' => '积分消耗总数',
'background_color' => 'layui-bg-cyan',
'sum' => self::setEchatWhere($where, null, true)->sum('use_integral'),
'class' => 'fa fa-line-chart',
'col' => 2
],
[
'name' => '积分抵扣金额',
'field' => '个',
'count' => self::setEchatWhere($where)->sum('deduction_price'),
'content' => '积分抵扣总金额',
'background_color' => 'layui-bg-cyan',
'sum' => self::setEchatWhere($where, null, true)->sum('deduction_price'),
'class' => 'fa fa-money',
'col' => 2
],
[
'name' => '在线支付金额',
'field' => '元',
'count' => self::setEchatWhere($where)->where(['paid' => 1, 'refund_status' => 0])->where('pay_type', 'weixin')->sum('pay_price'),
'content' => '在线支付总金额',
'background_color' => 'layui-bg-cyan',
'sum' => self::setEchatWhere($where, null, true)->where(['paid' => 1, 'refund_status' => 0])->where('pay_type', 'weixin')->sum('pay_price'),
'class' => 'fa fa-weixin',
'col' => 2
],
[
'name' => '余额支付金额',
'field' => '元',
'count' => self::setEchatWhere($where)->where('pay_type', 'yue')->where(['paid' => 1, 'refund_status' => 0])->sum('pay_price'),
'content' => '余额支付总金额',
'background_color' => 'layui-bg-cyan',
'sum' => self::setEchatWhere($where, null, true)->where(['paid' => 1, 'refund_status' => 0])->where('pay_type', 'yue')->sum('pay_price'),
'class' => 'fa fa-balance-scale',
'col' => 2
],
[
'name' => '赚取积分',
'field' => '分',
'count' => self::setEchatWhere($where)->sum('gain_integral'),
'content' => '赚取总积分',
'background_color' => 'layui-bg-cyan',
'sum' => self::setEchatWhere($where, null, true)->sum('gain_integral'),
'class' => 'fa fa-gg-circle',
'col' => 2
],
[
'name' => '交易额',
'field' => '元',
'count' => self::setEchatWhere($where)->where(['paid' => 1, 'refund_status' => 0])->sum('pay_price'),
'content' => '总交易额',
'background_color' => 'layui-bg-cyan',
'sum' => self::setEchatWhere($where, null, true)->where(['paid' => 1, 'refund_status' => 0])->sum('pay_price'),
'class' => 'fa fa-jpy',
'col' => 2
],
[
'name' => '订单商品数量',
'field' => '元',
'count' => self::setEchatWhere($where)->sum('total_num'),
'content' => '订单商品总数量',
'background_color' => 'layui-bg-cyan',
'sum' => self::setEchatWhere($where, null, true)->sum('total_num'),
'class' => 'fa fa-cube',
'col' => 2
]
];
}
/**
* 微信 订单发货
* @param $oid
* @param array $postageData
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\ModelNotFoundException
* @throws \think\exception\DbException
*/
public static function orderPostageAfter($oid, $postageData = [])
{
$order = self::where('id', $oid)->find();
$url = Url::buildUrl('/order/detail/' . $order['order_id'])->suffix('')->domain(true)->build();
$group = [
'first' => '亲,您的订单已发货,请注意查收',
'remark' => '点击查看订单详情'
];
if ($postageData['delivery_type'] == 'send') {//送货
$goodsName = StoreOrderCartInfo::getProductNameList($order['id']);
if ($order['is_channel'] == 1) {
//小程序送货模版消息
RoutineTemplate::sendOrderPostage($order);
} else {//公众号
$openid = WechatUser::where('uid', $order['uid'])->value('openid');
$group = array_merge($group, [
'keyword1' => $goodsName,
'keyword2' => $order['pay_type'] == 'offline' ? '线下支付' : date('Y/m/d H:i', $order['pay_time']),
'keyword3' => $order['user_address'],
'keyword4' => $postageData['delivery_name'],
'keyword5' => $postageData['delivery_id']
]);
WechatTemplateService::sendTemplate($openid, WechatTemplateService::ORDER_DELIVER_SUCCESS, $group, $url);
}
} else if ($postageData['delivery_type'] == 'express') {//发货
if ($order['is_channel'] == 1) {
//小程序发货模版消息
RoutineTemplate::sendOrderPostage($order, 1);
} else {//公众号
try {
$openid = WechatUser::where('uid', $order['uid'])->value('openid');
$content = "亲,您的订单{$order['order_id']}已发货,请注意查收！\n快递公司:{$order['delivery_name']}\n快递单号：{$order['delivery_id']}\n";
$content .= '点击查看物流信息';
WechatService::staffService()->message($content)->to($openid)->send();
}catch (\Exception $e){
}
// $group = array_merge($group, [
// 'keyword1' => $order['order_id'],
// 'keyword2' => $postageData['delivery_name'],
// 'keyword3' => $postageData['delivery_id']
// ]);
// WechatTemplateService::sendTemplate($openid, WechatTemplateService::ORDER_POSTAGE_SUCCESS, $group, $url);
}
}
}
/** 收货后发送模版消息
* @param $order
*/
public static function orderTakeAfter($order)
{
$title = '';
$cartInfo = StoreOrderCartInfo::where('oid', $order['id'])->column('cart_info', 'oid');
if (count($cartInfo)) {
foreach ($cartInfo as $key => &$cart) {
$cart = json_decode($cart, true);
$title .= $cart['productInfo']['store_name'] . ',';
}
}
if (strlen(trim($title)))
$title = substr($title, 0, bcsub(strlen($title), 1, 0));
else {
$cartInfo = StoreCart::alias('a')->where('a.id', 'in', implode(',', json_decode($order['cart_id'], true)))->find();
$title = StoreProduct::where('id', $cartInfo['product_id'])->value('store_name');
}
if ($order['is_channel'] == 1) {//小程序
RoutineTemplate::sendOrderTakeOver($order, $title);
} else {
$openid = WechatUser::where('uid', $order['uid'])->value('openid');
WechatTemplateService::sendTemplate($openid, WechatTemplateService::ORDER_TAKE_SUCCESS, [
'first' => '亲，您的订单已收货',
'keyword1' => $order['order_id'],
'keyword2' => '已收货',
'keyword3' => date('Y-m-d H:i:s', time()),
'keyword4' => $title,
'remark' => '感谢您的光临！'
]);
}
}
/**
* 不退款发送模板消息
* @param int $id 订单id
* @param array $data 退款详情
* */
public static function refundNoPrieTemplate($id, $data)
{
$order = self::get($id);
if ($order) return false;
//小程序模板消息
$cartInfo = StoreOrderCartInfo::where('oid', $order['id'])->column('product_id', 'oid') ?: [];
$title = '';
foreach ($cartInfo as $k => $productId) {
$store_name = StoreProduct::where('id', $productId)->value('store_name');
$title .= $store_name . ',';
}
if ($order->is_channel == 1) {
RoutineTemplate::sendOrderRefundFail($order, $title);
} else {
WechatTemplateService::sendTemplate(WechatUser::where('uid', $order->uid)->value('openid'), WechatTemplateService::ORDER_REFUND_STATUS, [
'first' => '很抱歉您的订单退款失败，失败原因：' . $data,
'keyword1' => $order->order_id,
'keyword2' => $order->pay_price,
'keyword3' => date('Y-m-d H:i:s', time()),
'remark' => '给您带来的不便，请谅解！'
], Url::buildUrl('/order/detail/' . $order['order_id'])->suffix('')->domain(true)->build());
}
}
/**
* 获取订单总数
* @param int $uid
* @return int|string
*/
public static function getOrderCount($uid = 0)
{
if (!$uid) return 0;
return self::where('uid', $uid)->where('paid', 1)->where('refund_status', 0)->where('status', 2)->count();
}
/**
* 获取已支付的订单
* @param int $is_promoter
* @return int|string
*/
public static function getOrderPayCount($is_promoter = 0)
{
return self::where('o.paid', 1)->alias('o')->join('User u', 'u.uid=o.uid')->where('u.is_promoter', $is_promoter)->count();
}
/**
* 获取最后一个月已支付的订单
* @param int $is_promoter
* @return int|string
*/
public static function getOrderPayMonthCount($is_promoter = 0)
{
return self::where('o.paid', 1)->alias('o')->whereTime('o.pay_time', 'last month')->join('User u', 'u.uid=o.uid')->where('u.is_promoter', $is_promoter)->count();
}
/** 订单收货处理积分
* @param $order
* @return bool
*/
public static function gainUserIntegral($order, bool $open = true)
{
if ($order['gain_integral'] > 0) {
$userInfo = User::get($order['uid']);
$open && BaseModel::beginTrans();
$integral = bcadd($userInfo['integral'], $order['gain_integral'], 2);
$res1 = false != User::where('uid', $userInfo['uid'])->update(['integral' => $integral]);
$res2 = false != UserBill::income('购买商品赠送积分', $order['uid'], 'integral', 'gain', $order['gain_integral'], $order['id'], bcadd($userInfo['integral'], $order['gain_integral'], 2), '购买商品赠送' . floatval($order['gain_integral']) . '积分');
$res = $res1 && $res2;
$open && BaseModel::checkTrans($res);
RoutineTemplate::sendUserIntegral($order['uid'], $order, $order['gain_integral'], $integral);
return $res;
}
return true;
}
public static function integralBack($id)
{
$order = self::get($id)->toArray();
if (!(float)bcsub($order['use_integral'], 0, 2) && !$order['back_integral']) return true;
if ($order['back_integral'] && !(int)$order['use_integral']) return true;
BaseModel::beginTrans();
$data['back_integral'] = bcsub($order['use_integral'], $order['use_integral'], 0);
if (!$data['back_integral']) return true;
$data['use_integral'] = 0;
$data['deduction_price'] = 0.00;
$data['pay_price'] = 0.00;
$data['coupon_id'] = 0.00;
$data['coupon_price'] = 0.00;
$res4 = true;
$integral = User::where('uid', $order['uid'])->value('integral');
$res1 = User::bcInc($order['uid'], 'integral', $data['back_integral'], 'uid');
$res2 = UserBill::income('商品退积分', $order['uid'], 'integral', 'pay_product_integral_back', $data['back_integral'], $order['id'], bcadd($integral, $data['back_integral'], 2), '订单退积分' . floatval($data['back_integral']) . '积分到用户积分');
$res3 = self::edit($data, $id);
if ($order['coupon_id']) $res4 = StoreCouponUser::recoverCoupon($order['coupon_id']);
StoreOrderStatus::setStatus($id, 'integral_back', '商品退积分：' . $data['back_integral']);
$res = $res1 && $res2 && $res3 && $res4;
BaseModel::checkTrans($res);
return $res;
}
/**
* 订单数量 支付方式
* @return array
*/
public static function payTypeCount()
{
$where['status'] = 8;
$where['is_del'] = 0;
$where['real_name'] = '';
$where['data'] = '';
$where['type'] = '';
$where['order'] = '';
$where['pay_type'] = 1;
$weixin = self::getOrderWhere($where, new self)->count();
$where['pay_type'] = 2;
$yue = self::getOrderWhere($where, new self)->count();
$where['pay_type'] = 3;
$offline = self::getOrderWhere($where, new self)->count();
return compact('weixin', 'yue', 'offline');
}
public static function list($where)
{
$model = self::alias('a')
->field('*')
->order('id DESC');
if ($where['uid']) $model->where('uid', $where['uid']);
if ($where['spread_uid']){
$uids = User::where('spread_uid', $where['spread_uid'])->column('uid');
$model->where('uid', 'in', $uids);
}
$data['count'] = $model->count();
if ($where['page'] && $where['limit']){
$model->page($where['page'], $where['limit']);
}else{
$model->page(20, 1);
}
$list = $model->select();
$list = count($list) ? $list->toArray() : [];
foreach ($list as &$item)
{
$user = User::where('uid', $item['uid'])->find();
if ($user['spread_uid']){
$spread = User::where('uid', $user['spread_uid'])->find();
}else{
$spread['nickname'] = '没有推广人';
}
$item['nickname'] = $user['nickname'].'/'.$user['uid'];
$item['spread_name'] = $spread['nickname'].'/'.$user['spread_uid'];
}
$data['data'] = $list;
return $data;
}
}