CRMEB/crmeb/app/api/controller/v1/admin/StoreOrderController.php
2026-03-23 14:57:47 +08:00

684 lines
27 KiB
PHP
Raw Blame History

This file contains ambiguous Unicode characters

This file contains Unicode characters that might be confused with other characters. If you think that this is intentional, you can safely ignore this warning. Use the Escape button to reveal them.

<?php
// +----------------------------------------------------------------------
// | CRMEB [ CRMEB赋能开发者助力企业发展 ]
// +----------------------------------------------------------------------
// | Copyright (c) 2016~2026 https://www.crmeb.com All rights reserved.
// +----------------------------------------------------------------------
// | Licensed CRMEB并不是自由软件未经许可不能去掉CRMEB相关版权
// +----------------------------------------------------------------------
// | Author: CRMEB Team <admin@crmeb.com>
// +----------------------------------------------------------------------
namespace app\api\controller\v1\admin;
use app\Request;
use app\services\order\DeliveryServiceServices;
use app\services\order\StoreOrderCartInfoServices;
use app\services\order\StoreOrderCreateServices;
use app\services\order\StoreOrderDeliveryServices;
use app\services\order\StoreOrderEconomizeServices;
use app\services\order\StoreOrderRefundServices;
use app\services\order\StoreOrderServices;
use app\services\order\StoreOrderWapServices;
use app\services\order\StoreOrderWriteOffServices;
use app\services\pay\OrderOfflineServices;
use app\services\serve\ServeServices;
use app\services\user\UserServices;
use app\services\shipping\ExpressServices;
/**
* 订单类
* Class StoreOrderController
* @package app\api\controller\admin\order
*/
class StoreOrderController
{
/**
* @var StoreOrderWapServices
*/
protected $service;
/**
* StoreOrderController constructor.
* @param StoreOrderWapServices $services
*/
public function __construct(StoreOrderWapServices $services)
{
$this->service = $services;
}
/**
* 订单 查看物流
* @param StoreOrderCartInfoServices $services
* @param ExpressServices $expressServices
* @param $uni
* @param string $type
* @return mixed
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\DbException
* @throws \think\db\exception\ModelNotFoundException
*/
public function express(StoreOrderServices $orderServices, StoreOrderCartInfoServices $services, ExpressServices $expressServices, $uni, $type = '')
{
if ($type == 'refund') {
/** @var StoreOrderRefundServices $refundService */
$refundService = app()->make(StoreOrderRefundServices::class);
$order = $refundService->refundDetail($uni);
$express = $order['refund_express'];
$cacheName = $uni . $express;
$orderInfo = [];
$info = [];
$cartNew = [];
foreach ($order['cart_info'] as $k => $cart) {
$cartNew['cart_num'] = $cart['cart_num'];
$cartNew['truePrice'] = $cart['truePrice'];
$cartNew['postage_price'] = $cart['postage_price'];
$cartNew['productInfo']['image'] = $cart['productInfo']['image'];
$cartNew['productInfo']['store_name'] = $cart['productInfo']['store_name'];
$cartNew['productInfo']['unit_name'] = $cart['productInfo']['unit_name'] ?? '';
array_push($info, $cartNew);
unset($cart);
}
$orderInfo['cartInfo'] = $info;
$orderInfo['delivery_id'] = $express;
$orderInfo['delivery_name'] = $order['refund_express_name'];
$orderInfo['delivery_code'] = '';
} else {
if (!$uni || !($order = $orderServices->getUserOrderDetail($uni, 0, []))) {
return app('json')->fail('订单不存在');
}
if ($type != 'refund' && ($order['delivery_type'] != 'express' || !$order['delivery_id'])) {
return app('json')->fail('快递单号不存在');
}
$express = $type == 'refund' ? $order['refund_express'] : $order['delivery_id'];
$cacheName = $uni . $express;
$orderInfo = [];
$cartInfo = $services->getCartColunm(['oid' => $order['id']], 'cart_info', 'unique');
$info = [];
$cartNew = [];
foreach ($cartInfo as $k => $cart) {
$cart = json_decode($cart, true);
$cartNew['cart_num'] = $cart['cart_num'];
$cartNew['truePrice'] = $cart['truePrice'];
$cartNew['postage_price'] = $cart['postage_price'];
$cartNew['productInfo']['image'] = $cart['productInfo']['image'];
$cartNew['productInfo']['store_name'] = $cart['productInfo']['store_name'];
$cartNew['productInfo']['unit_name'] = $cart['productInfo']['unit_name'] ?? '';
array_push($info, $cartNew);
unset($cart);
}
$orderInfo['delivery_id'] = $express;
$orderInfo['delivery_name'] = $type == 'refund' ? '用户退回' : $order['delivery_name'];;
$orderInfo['delivery_code'] = $type == 'refund' ? '' : $order['delivery_code'];
$orderInfo['delivery_type'] = $order['delivery_type'];
$orderInfo['user_address'] = $order['user_address'];
$orderInfo['user_mark'] = $order['mark'];
$orderInfo['cartInfo'] = $info;
}
return app('json')->success([
'order' => $orderInfo,
'express' => [
'result' => ['list' => $expressServices->query($cacheName, $orderInfo['delivery_id'], $orderInfo['delivery_code'], $order['user_phone'])
]
]
]);
}
/**
* 订单数据统计
* @param StoreOrderServices $services
* @return mixed
*/
public function statistics(StoreOrderServices $services)
{
$dataCount = $services->getOrderData();
$dataPrice = $this->service->getOrderTimeData();
$data = array_merge($dataCount, $dataPrice);
return app('json')->success($data);
}
/**
* 订单每月统计数据
* @param Request $request
* @return mixed
*/
public function data(Request $request)
{
[$start, $stop] = $request->getMore([
['start', 0],
['stop', 0]
], true);
return app('json')->success($this->service->getOrderDataPriceCount(['time' => [$start, $stop]]));
}
/**
* 订单列表
* @param Request $request
* @return mixed
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\DbException
* @throws \think\db\exception\ModelNotFoundException
*/
public function lst(Request $request)
{
$where = $request->getMore([
['status', ''],
['is_del', 0],
['data', '', '', 'time'],
['type', ''],
['field_key', ''],
['field_value', ''],
['keyword', '', '', 'real_name'],
['pay_type', ''],
]);
$where['is_system_del'] = 0;
if (!in_array($where['status'], [-1, -2, -3])) {
$where['pid'] = 0;
}
return app('json')->success($this->service->getWapAdminOrderList($where));
}
/**
* 订单详情
* @param Request $request
* @param StoreOrderServices $services
* @param UserServices $userServices
* @param $orderId
* @return mixed
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\DbException
* @throws \think\db\exception\ModelNotFoundException
*/
public function detail(Request $request, StoreOrderServices $services, UserServices $userServices, $orderId)
{
$economizeServices = app()->make(StoreOrderEconomizeServices::class);
$orderData = $services->getUserOrderByKey($economizeServices, $orderId, 0);
$orderData['nickname'] = $userServices->value(['uid' => $orderData['uid']], 'nickname');
return app('json')->success($orderData);
}
/**
* 订单发货获取订单信息
* @param UserServices $userServices
* @param $orderId
* @return mixed
*/
public function delivery_gain(UserServices $userServices, $orderId)
{
$order = $this->service->getOne(['order_id' => $orderId], 'real_name,user_phone,user_address,order_id,uid,status,paid,id');
if (!$order) return app('json')->fail('订单不存在');
if ($order['paid']) {
$order['nickname'] = $userServices->value(['uid' => $order['uid']], 'nickname');
$order['config_export_open'] = (bool)((int)sys_config('config_export_open'));
$order = $order->hidden(['uid', 'status', 'paid'])->toArray();
return app('json')->success($order);
}
return app('json')->fail('获取失败');
}
/**
* 订单发货
* @param Request $request
* @param StoreOrderDeliveryServices $services
* @param $id
* @return mixed
*/
public function delivery_keep(Request $request, StoreOrderDeliveryServices $services, $id)
{
$data = $request->postMore([
['type', 1],
['delivery_name', ''],//快递公司id
['delivery_id', ''],//快递单号
['delivery_code', ''],//快递公司编码
['delivery_type', ''],//快递公司名称
['express_record_type', 2],//发货记录类型
['express_temp_id', ""],//电子面单模板
['to_name', ''],//寄件人姓名
['to_tel', ''],//寄件人电话
['to_addr', ''],//寄件人地址
['sh_delivery_name', ''],//送货人姓名
['sh_delivery_id', ''],//送货人电话
['sh_delivery_uid', ''],//送货人ID
['fictitious_content', ''],//虚拟发货内容
['pickup_time', []]
]);
if ($data['delivery_type']) {
$data['delivery_name'] = $data['delivery_type'];
unset($data['delivery_type']);
}
$services->delivery((int)$id, $data);
return app('json')->success('发货成功');
}
/**
* 订单改价
* @param Request $request
* @param StoreOrderServices $services
* @return mixed
* @throws \Exception
*/
public function price(Request $request, StoreOrderServices $services)
{
[$order_id, $price] = $request->postMore([
['order_id', ''],
['price', '']
], true);
$order = $this->service->getOne(['order_id' => $order_id], 'id,user_phone,id,paid,pay_price,order_id,total_price,total_postage,pay_postage,gain_integral');
if (!$order) return app('json')->fail('订单不存在');
if ($order['paid']) {
return app('json')->fail('订单已支付');
}
if ($price === '') return app('json')->fail('请填写实际支付金额');
if ($price < 0) return app('json')->fail('实际支付金额不能小于0元');
if ($order['pay_price'] == $price) return app('json')->success('修改成功', ['order_id' => $order_id]);
$order_id = $services->updateOrder($order['id'], ['total_price' => $order['total_price'], 'pay_price' => $price]);
return app('json')->success('修改成功', ['order_id' => $order_id]);
}
/**
* 订单备注
* @param Request $request
* @return mixed
*/
public function remark(Request $request)
{
[$order_id, $remark] = $request->postMore([
['order_id', ''],
['remark', '']
], true);
$order = $this->service->getOne(['order_id' => $order_id], 'id,remark');
if (!$order) return app('json')->fail('订单不存在');
if (!strlen(trim($remark))) return app('json')->fail('请填写备注内容');
$order->remark = $remark;
if (!$order->save())
return app('json')->fail('备注失败');
return app('json')->success('备注成功');
}
/**
* 订单交易额/订单数量时间统计
* @param Request $request
* @return bool
*/
public function time(Request $request)
{
list($start, $stop, $type) = $request->getMore([
['start', strtotime(date('Y-m'))],
['stop', time()],
['type', 1]
], true);
$start = strtotime(date('Y-m-d 00:00:00', (int)$start));
$stop = strtotime(date('Y-m-d 23:59:59', (int)$stop));
if ($start > $stop) {
$middle = $stop;
$stop = $start;
$start = $middle;
}
$space = bcsub($stop, $start, 0);//间隔时间段
$front = bcsub($start, $space, 0) - 1;//第一个时间段
/** @var StoreOrderServices $orderService */
$orderService = app()->make(StoreOrderServices::class);
$order_where = [
'pid' => 0,
'paid' => 1,
'refund_status' => [0, 3],
'is_del' => 0,
'is_system_del' => 0
];
if ($type == 1) {//销售额
$frontPrice = $orderService->sum($order_where + ['time' => [$front, $start - 1]], 'pay_price', true);
$afterPrice = $orderService->sum($order_where + ['time' => [$start, $stop]], 'pay_price', true);
$chartInfo = $orderService->chartTimePrice($start, $stop);
$data['chart'] = $chartInfo;//营业额图表数据
$data['time'] = $afterPrice;//时间区间营业额
$increase = (float)bcsub((string)$afterPrice, (string)$frontPrice, 2); //同比上个时间区间增长营业额
$growthRate = abs($increase);
if ($growthRate == 0) $data['growth_rate'] = 0;
else if ($frontPrice == 0) $data['growth_rate'] = (int)bcmul($growthRate, 100, 0);
else $data['growth_rate'] = (int)bcmul((string)bcdiv((string)$growthRate, (string)$frontPrice, 2), '100', 0);//时间区间增长率
$data['increase_time'] = abs($increase); //同比上个时间区间增长营业额
$data['increase_time_status'] = $increase >= 0 ? 1 : 2; //同比上个时间区间增长营业额增长 1 减少 2
} else {//订单数
$frontNumber = $orderService->count($order_where + ['time' => [$front, $start - 1]]);
$afterNumber = $orderService->count($order_where + ['time' => [$start, $stop]]);
$chartInfo = $orderService->chartTimeNumber($start, $stop);
$data['chart'] = $chartInfo;//订单数图表数据
$data['time'] = $afterNumber;//时间区间订单数
$increase = $afterNumber - $frontNumber; //同比上个时间区间增长订单数
$growthRate = abs($increase);
if ($growthRate == 0) $data['growth_rate'] = 0;
else if ($frontNumber == 0) $data['growth_rate'] = (int)bcmul($growthRate, 100, 0);
else $data['growth_rate'] = (int)bcmul((string)bcdiv((string)$growthRate, (string)$frontNumber, 2), '100', 0);//时间区间增长率
$data['increase_time'] = abs($increase); //同比上个时间区间增长营业额
$data['increase_time_status'] = $increase >= 0 ? 1 : 2; //同比上个时间区间增长营业额增长 1 减少 2
}
return app('json')->success($data);
}
/**
* 订单支付
* @param Request $request
* @param OrderOfflineServices $services
* @return mixed
*/
public function offline(Request $request, OrderOfflineServices $services)
{
[$orderId] = $request->postMore([['order_id', '']], true);
$orderInfo = $this->service->getOne(['order_id' => $orderId], 'id');
if (!$orderInfo) return app('json')->fail('参数错误');
$id = $orderInfo->id;
$services->orderOffline((int)$id);
return app('json')->success('操作成功');
}
/**
* 订单退款
* @param Request $request
* @param StoreOrderRefundServices $services
* @param StoreOrderServices $orderServices
* @param StoreOrderCartInfoServices $storeOrderCartInfoServices
* @param StoreOrderCreateServices $storeOrderCreateServices
* @return mixed
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\DbException
* @throws \think\db\exception\ModelNotFoundException
*/
public function refund(Request $request, StoreOrderRefundServices $services, StoreOrderServices $orderServices, StoreOrderCartInfoServices $storeOrderCartInfoServices, StoreOrderCreateServices $storeOrderCreateServices)
{
list($orderId, $price, $type) = $request->postMore([
['order_id', ''],
['price', '0'],
['type', 1],
], true);
if (!strlen(trim($orderId))) return app('json')->fail('参数错误');
//退款订单详情
$orderRefund = $services->getOne(['order_id' => $orderId]);
$is_admin = 0;
if (!$orderRefund) {
//主动退款主订单详情
$orderRefund = $orderServices->getOne(['order_id' => $orderId]);
$is_admin = 1;
if ($services->count(['store_order_id' => $orderRefund['id'], 'refund_type' => [0, 1, 2, 4, 5], 'is_cancel' => 0, 'is_del' => 0])) {
return app('json')->fail('请先处理售后申请');
}
}
if (!$is_admin) {
if (!$orderRefund) {
return app('json')->fail('数据不存在');
}
if ($orderRefund['is_cancel'] == 1) {
return app('json')->fail('用户已取消申请');
}
$orderInfo = $this->service->get((int)$orderRefund['store_order_id']);
if (!$orderInfo) {
return app('json')->fail('数据不存在');
}
if (!in_array($orderRefund['refund_type'], [1, 2, 5])) {
return app('json')->fail('售后订单状态不支持该操作');
}
if ($type == 1) {
$data['refund_type'] = 6;
} else if ($type == 2) {
$data['refund_type'] = 3;
} else {
return app('json')->fail('退款修改状态错误');
}
$data['refunded_time'] = time();
//拒绝退款
if ($type == 2) {
$services->refuseRefund((int)$orderRefund['id'], $data, $orderRefund);
return app('json')->success('修改退款状态成功');
} else {
if ($orderRefund['refund_price'] == $orderInfo['refunded_price']) return app('json')->fail('已退完支付金额,不能再退款了');
if (!$price) {
return app('json')->fail('请输入退款金额');
}
$data['refunded_price'] = bcadd($price, $orderRefund['refunded_price'], 2);
$bj = bccomp((float)$orderRefund['refund_price'], (float)$data['refunded_price'], 2);
if ($bj < 0) {
return app('json')->fail('退款金额大于支付金额,请修改退款金额');
}
$refundData['pay_price'] = $orderInfo['pay_price'];
$refundData['refund_price'] = $price;
$refundData['order_id'] = $orderId;
//修改订单退款状态
if ($services->agreeRefund((int)$orderRefund['id'], $refundData)) {
$services->update((int)$orderRefund['id'], $data);
return app('json')->success('退款成功');
} else {
$services->storeProductOrderRefundYFasle((int)$orderInfo['id'], $price);
return app('json')->fail('退款失败');
}
}
} else {
$order = $orderRefund;
$data['refund_price'] = $price;
$data['type'] = $type;
$id = $order['id'];
//0元退款
if ($order['pay_price'] == 0 && in_array($order['refund_status'], [0, 1])) {
$refund_price = 0;
} else {
if ($order['pay_price'] == $order['refund_price']) {
return app('json')->fail('已退完支付金额,不能再退款了');
}
if (!$data['refund_price']) {
return app('json')->fail('请输入退款金额');
}
$refund_price = $data['refund_price'];
$data['refund_price'] = bcadd($data['refund_price'], $order['refund_price'], 2);
$bj = bccomp((string)$order['pay_price'], (string)$data['refund_price'], 2);
if ($bj < 0) {
return app('json')->fail('退款金额大于支付金额,请修改退款金额');
}
}
if ($data['type'] == 1) {
$data['refund_status'] = 2;
$data['refund_type'] = 6;
} else if ($data['type'] == 2) {
$data['refund_status'] = 0;
$data['refund_type'] = 3;
}
$type = $data['type'];
//拒绝退款
if ($type == 2) {
$this->service->update((int)$order['id'], ['refund_status' => 0, 'refund_type' => 3]);
return app('json')->success('修改退款状态成功');
} else {
unset($data['type']);
$refund_data['pay_price'] = $order['pay_price'];
$refund_data['refund_price'] = $refund_price;
//主动退款清楚原本退款单
$services->delete(['store_order_id' => $id]);
//生成退款订单
$refundOrderData['uid'] = $order['uid'];
$refundOrderData['store_id'] = $order['store_id'];
$refundOrderData['store_order_id'] = $id;
$refundOrderData['refund_num'] = $order['total_num'];
$refundOrderData['refund_type'] = $data['refund_type'];
$refundOrderData['refund_price'] = $order['pay_price'];
$refundOrderData['refunded_price'] = $refund_price;
$refundOrderData['refunded_reason'] = '管理员手动退款';
$refundOrderData['order_id'] = $storeOrderCreateServices->getNewOrderId('');
$refundOrderData['refunded_time'] = time();
$refundOrderData['add_time'] = time();
$cartInfos = $storeOrderCartInfoServices->getCartColunm(['oid' => $id], 'id,cart_id,cart_num,cart_info');
foreach ($cartInfos as &$cartInfo) {
$cartInfo['cart_info'] = is_string($cartInfo['cart_info']) ? json_decode($cartInfo['cart_info'], true) : $cartInfo['cart_info'];
}
$refundOrderData['cart_info'] = json_encode(array_column($cartInfos, 'cart_info'));
$res = $services->save($refundOrderData);
$refund_data['order_id'] = $refundOrderData['order_id'];
//修改订单退款状态
if ($services->agreeRefund((int)$res->id, $refund_data)) {
$this->service->update($id, $data);
return app('json')->success('退款成功');
} else {
$services->storeProductOrderRefundYFasle((int)$id, $refund_price);
return app('json')->fail('退款失败');
}
}
}
}
/**
* 门店核销
* @param Request $request
* @param StoreOrderWriteOffServices $services
* @return mixed
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\DbException
* @throws \think\db\exception\ModelNotFoundException
*/
public function order_verific(Request $request, StoreOrderWriteOffServices $services)
{
list($verifyCode, $isConfirm, $auth) = $request->postMore([
['verify_code', ''],
['is_confirm', 0],
['auth', 0],
], true);
if (!$verifyCode) return app('json')->fail('请输入核销码或者扫描核销二维码');
$uid = $request->uid();
$orderInfo = $services->writeOffOrder($verifyCode, (int)$isConfirm, $uid, $auth);
if ($isConfirm == 0) {
return app('json')->success($orderInfo);
}
return app('json')->success('核销成功');
}
/**
* 获取所有配送员列表
* @param DeliveryServiceServices $services
* @return mixed
*/
public function getDeliveryAll(DeliveryServiceServices $services)
{
$list = $services->getDeliveryList();
return app('json')->success($list['list']);
}
/**
* 获取配置信息
* @return mixed
*/
public function getDeliveryInfo()
{
return app('json')->success([
'express_temp_id' => sys_config('config_export_temp_id'),
'to_name' => sys_config('config_export_to_name'),
'id' => sys_config('config_export_id'),
'to_tel' => sys_config('config_export_to_tel'),
'to_add' => sys_config('config_export_to_address')
]);
}
/**
* 获取面单信息
* @param Request $request
* @param ServeServices $services
* @return mixed
*/
public function getExportTemp(Request $request, ServeServices $services)
{
[$com] = $request->getMore([
['com', ''],
], true);
return app('json')->success($services->express()->temp($com));
}
/**
* 物流公司
* @param ExpressServices $services
* @return mixed
*/
public function getExportAll(ExpressServices $services)
{
return app('json')->success($services->expressList());
}
/**
* 移动端订单管理退款列表
* @param Request $request
* @param StoreOrderRefundServices $services
* @return mixed
*/
public function refundOrderList(Request $request, StoreOrderRefundServices $services)
{
$where = $request->getMore([
['order_id', ''],
['time', ''],
['refund_type', ''],
['refundTypes', 0],
['keywords', '', '', 'real_name'],
]);
$where['is_cancel'] = 0;
$data = $services->refundList($where)['list'];
return app('json')->success($data);
}
/**
* 订单详情
* @param StoreOrderRefundServices $services
* @param $uni
* @return mixed
*/
public function refundOrderDetail(StoreOrderRefundServices $services, $uni)
{
$data = $services->refundDetail($uni);
return app('json')->success($data);
}
/**
* 退款备注
* @param StoreOrderRefundServices $services
* @param Request $request
* @return mixed
*/
public function refundRemark(StoreOrderRefundServices $services, Request $request)
{
[$remark, $order_id] = $request->postMore([
['remark', ''],
['order_id', ''],
], true);
if (!$remark)
return app('json')->fail('请填写备注内容');
if (!$order_id)
return app('json')->fail('参数错误');
if (!$order = $services->get(['order_id' => $order_id])) {
return app('json')->fail('订单不存在');
}
$order->remark = $remark;
if ($order->save()) {
return app('json')->success('备注成功');
} else
return app('json')->fail('备注失败');
}
/**
* 同意退货
* @param StoreOrderRefundServices $services
* @param Request $request
* @return mixed
*/
public function agreeExpress(StoreOrderRefundServices $services, Request $request)
{
[$id] = $request->postMore([
['id', ''],
], true);
$services->agreeExpress($id);
return app('json')->success('操作成功');
}
}