OrderService.php 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897
  1. <?php
  2. // +----------------------------------------------------------------------
  3. // | LARAVEL8.0 框架 [ LARAVEL ][ RXThinkCMF ]
  4. // +----------------------------------------------------------------------
  5. // | 版权所有 2017~2021 LARAVEL研发中心
  6. // +----------------------------------------------------------------------
  7. // | 官方网站: http://www.laravel.cn
  8. // +----------------------------------------------------------------------
  9. // | Author: laravel开发员 <laravel.qq.com>
  10. // +----------------------------------------------------------------------
  11. namespace App\Services\Common;
  12. use App\Models\AccountLogModel;
  13. use App\Models\ActionLogModel;
  14. use App\Models\GoodsModel;
  15. use App\Models\MemberModel;
  16. use App\Models\MessageModel;
  17. use App\Models\OrderModel;
  18. use App\Models\OrderGoodsModel;
  19. use App\Models\StoreModel;
  20. use App\Services\Api\SettleService;
  21. use App\Services\BaseService;
  22. use App\Services\RedisService;
  23. use Illuminate\Support\Facades\DB;
  24. /**
  25. * 订单管理-服务类
  26. * @author laravel开发员
  27. * @since 2020/11/11
  28. * Class OrderService
  29. * @package App\Services\Common
  30. */
  31. class OrderService extends BaseService
  32. {
  33. // 静态对象
  34. protected static $instance = null;
  35. /**
  36. * 构造函数
  37. * @author laravel开发员
  38. * @since 2020/11/11
  39. * OrderService constructor.
  40. */
  41. public function __construct()
  42. {
  43. $this->model = new OrderModel();
  44. }
  45. /**
  46. * 静态入口
  47. * @return static|null
  48. */
  49. public static function make()
  50. {
  51. if (!self::$instance) {
  52. self::$instance = (new static());
  53. }
  54. return self::$instance;
  55. }
  56. /**
  57. * @param $params
  58. * @param int $pageSize
  59. * @return array
  60. */
  61. public function getDataList($params, $pageSize = 15)
  62. {
  63. $query = $this->model->where('mark', 1);
  64. // 店铺筛选
  65. if (isset($params['store_id']) && $params['store_id'] > 0) {
  66. $query->where('store_id', $params['store_id']);
  67. }
  68. // 用户筛选
  69. if (isset($params['user_id']) && $params['user_id'] > 0) {
  70. $query->where('user_id', $params['user_id']);
  71. }
  72. // 状态筛选
  73. if (isset($params['status']) && $params['status'] > 0) {
  74. $query->where('status', $params['status']);
  75. }
  76. // 售后类型筛选(1-售后,2-退款)
  77. if (isset($params['after_type']) && $params['after_type'] > 0) {
  78. $query->where('after_type', $params['after_type']);
  79. }
  80. // 退款状态筛选
  81. if (isset($params['refund_status']) && $params['refund_status'] > 0) {
  82. $query->where('refund_status', $params['refund_status']);
  83. }
  84. // 关键词搜索(订单号、商品名称、收货人手机)
  85. if (isset($params['keyword']) && $params['keyword']) {
  86. $keyword = $params['keyword'];
  87. $query->where(function ($q) use ($keyword) {
  88. $q->where('order_no', 'like', '%' . $keyword . '%')
  89. ->orWhere('receiver_name', 'like', '%' . $keyword . '%')
  90. ->orWhere('receiver_mobile', 'like', '%' . $keyword . '%')
  91. ->orWhereHas('orderGoods', function ($q2) use ($keyword) {
  92. $q2->where('goods_name', 'like', '%' . $keyword . '%');
  93. });
  94. });
  95. }
  96. $list = $query->with(['user', 'orderGoods', 'store'])
  97. ->orderBy('create_time', 'desc')
  98. ->orderBy('id', 'desc')
  99. ->paginate($pageSize);
  100. $list = $list ? $list->toArray() : [];
  101. if ($list && isset($list['data'])) {
  102. foreach ($list['data'] as &$item) {
  103. $item['create_time'] = $item['create_time'] ? datetime($item['create_time']) : '';$item['user'] = $item['user'] ?? [];
  104. $item['store'] = $item['store'] ?? [];
  105. // 获取第一个商品信息(thumb已通过Model访问器处理)
  106. $item['goods'] = isset($item['order_goods'][0]) ? $item['order_goods'][0] : null;
  107. }
  108. }
  109. return [
  110. 'msg' => '操作成功',
  111. 'code' => 0,
  112. 'data' => $list['data'] ?? [],
  113. 'count' => $list['total'] ?? 0,
  114. ];
  115. }
  116. /**
  117. * 获取订单详情
  118. */
  119. public function getInfo($id)
  120. {
  121. $info = $this->model->where('id', $id)->where('mark', 1)
  122. ->with(['user', 'orderGoods', 'store','recUser'])
  123. ->first();
  124. if (!$info) {
  125. return ['code' => 1, 'msg' => '订单不存在'];
  126. }
  127. $info = $info->toArray();
  128. $info['create_time'] = $info['create_time'] ? date('Y-m-d H:i:s', strtotime($info['create_time'])) : '';
  129. $info['update_time'] = $info['update_time'] ? date('Y-m-d H:i:s', strtotime($info['update_time'])) : '';
  130. if (isset($info['order_goods'])) {
  131. foreach ($info['order_goods'] as &$goods) {
  132. $goods['thumb'] = $goods['thumb'] ? get_image_url($goods['thumb']) : '';
  133. $goods['create_time'] = $goods['create_time'] ? date('Y-m-d H:i:s', strtotime($goods['create_time'])) : '';
  134. $goods['update_time'] = $goods['update_time'] ? date('Y-m-d H:i:s', strtotime($goods['update_time'])) : '';
  135. }
  136. }
  137. return ['code' => 0, 'msg' => '操作成功', 'data' => $info];
  138. }
  139. /**
  140. * 查询
  141. * @param $params
  142. * @return \Illuminate\Database\Eloquent\Builder
  143. */
  144. public function getQuery($params)
  145. {
  146. $where = ['a.mark' => 1];
  147. $userId = isset($params['user_id']) ? $params['user_id'] : 0;
  148. return $this->model->with(['user', 'goods'])->from('orders as a')
  149. ->leftJoin('member as b', 'a.user_id', '=', 'b.id')
  150. ->leftJoin('goods as c', 'c.id', '=', 'a.goods_id')
  151. ->where($where)
  152. ->where(function ($query) use ($params) {
  153. $keyword = isset($params['keyword']) ? $params['keyword'] : '';
  154. if ($keyword) {
  155. $query->where('a.order_no', 'like', "%{$keyword}%");
  156. }
  157. // 接单人
  158. $account = isset($params['account']) ? $params['account'] : '';
  159. if ($account) {
  160. $query->where(function ($query) use ($account) {
  161. $query->where('b.nickname', 'like', "%{$account}%")->orWhere('b.mobile', 'like', "%{$account}%");
  162. });
  163. }
  164. // 商品
  165. $goodsId = isset($params['goods_id']) ? intval($params['goods_id']) : 0;
  166. $goods = isset($params['goods']) ? trim($params['goods']) : '';
  167. if ($goods) {
  168. $query->where(function ($query) use ($goods) {
  169. $query->where('c.goods_name', 'like', "%{$goods}%");
  170. if (preg_match("/^(1[0-9]+|[1-9]+)$/", $goods)) {
  171. $query->where('a.goods_id', intval($goods));
  172. } else {
  173. $query->where('c.goods_name', 'like', "%{$goods}%");
  174. }
  175. });
  176. }
  177. if ($goodsId > 0) {
  178. $query->where('a.goods_id', intval($goodsId));
  179. }
  180. })
  181. ->where(function ($query) use ($params) {
  182. $status = isset($params['status']) ? $params['status'] : 0;
  183. if ($status == 0) {
  184. $query->whereIn('a.status', [2, 3]);
  185. } else if ($status) {
  186. $query->where('a.status', $status);
  187. }
  188. })
  189. ->where(function ($query) use ($userId) {
  190. if ($userId) {
  191. $query->where('a.user_id', '=', $userId);
  192. }
  193. });
  194. }
  195. /**
  196. * 按日期统计订单数
  197. * @param string $beginAt 开始时间
  198. * @param string $endAt 结束时间
  199. * @param int[] $status 状态:数组或数值
  200. * @return mixed
  201. */
  202. public function getCountByTime($beginAt = '', $endAt = '', $status = 3)
  203. {
  204. $cacheKey = "caches:orders:count_{$status}_{$beginAt}_{$endAt}";
  205. $data = RedisService::get($cacheKey);
  206. if ($data) {
  207. return $data;
  208. }
  209. $where = ['mark' => 1];
  210. $data = $this->model->where($where)->where(function ($query) use ($beginAt, $endAt, $status) {
  211. if ($beginAt && $endAt) {
  212. $query->whereBetween('create_time', [strtotime($beginAt), strtotime($endAt)]);
  213. } else if ($beginAt) {
  214. $query->where('create_time', '>=', strtotime($beginAt));
  215. }
  216. if ($status && is_array($status)) {
  217. $query->whereIn('status', $status);
  218. } else if ($status) {
  219. $query->where('status', $status);
  220. }
  221. })->count('id');
  222. if ($data) {
  223. RedisService::set($cacheKey, $data, rand(300, 600));
  224. }
  225. return $data;
  226. }
  227. /**
  228. * 按日期统计订单金额
  229. * @param string $beginAt 开始时间
  230. * @param string $endAt 结束时间
  231. * @param int[] $status 状态:数组或数值
  232. * @return mixed
  233. */
  234. public function getTotalByTime($beginAt = '', $endAt = '', $status = 3)
  235. {
  236. $cacheKey = "caches:orders:total_{$status}_{$beginAt}_{$endAt}";
  237. $data = RedisService::get($cacheKey);
  238. if ($data) {
  239. return $data;
  240. }
  241. $where = ['mark' => 1];
  242. $data = $this->model->where($where)->where(function ($query) use ($beginAt, $endAt, $status) {
  243. if ($beginAt && $endAt) {
  244. $query->whereBetween('create_time', [strtotime($beginAt), strtotime($endAt)]);
  245. } else if ($beginAt) {
  246. $query->where('create_time', '>=', strtotime($beginAt));
  247. }
  248. if ($status && is_array($status)) {
  249. $query->whereIn('status', $status);
  250. } else if ($status) {
  251. $query->where('status', $status);
  252. }
  253. })->sum('total');
  254. if ($data) {
  255. RedisService::set($cacheKey, $data, rand(300, 600));
  256. }
  257. return $data;
  258. }
  259. /**
  260. * 添加或编辑
  261. * @return array
  262. * @since 2020/11/11
  263. * @author laravel开发员
  264. */
  265. public function edit()
  266. {
  267. $params = request()->post();
  268. return parent::edit($params); // TODO: Change the autogenerated stub
  269. }
  270. /**
  271. * 完成支付
  272. */
  273. public function completePay()
  274. {
  275. $id = request()->post('id');
  276. $transactionId = request()->post('transaction_id', '');
  277. if (!$id) {
  278. return ['code' => 1, 'msg' => '参数错误'];
  279. }
  280. $order = $this->model->find($id);
  281. if (!$order) {
  282. return ['code' => 1, 'msg' => '订单不存在'];
  283. }
  284. if ($order->status != 1) {
  285. return ['code' => 1, 'msg' => '订单状态不正确'];
  286. }
  287. $updateData = [
  288. 'status' => 2, // 已付款
  289. 'transaction_id' => $transactionId ?: 'PAY' . time() . rand(1000, 9999),
  290. 'pay_at'=> date('Y-m-d H:i:s'),
  291. 'remark'=> '人工审核支付',
  292. 'update_time' => time()
  293. ];
  294. $result = $this->model->where('id', $id)->update($updateData);
  295. if ($result) {
  296. ActionLogModel::setTitle("订单完成支付");
  297. ActionLogModel::record();
  298. RedisService::keyDel("caches:orders:*");
  299. return ['code' => 0, 'msg' => '支付完成'];
  300. }
  301. return ['code' => 1, 'msg' => '操作失败'];
  302. }
  303. /**
  304. * 订单发货
  305. */
  306. public function deliverOrder()
  307. {
  308. $id = request()->post('id');
  309. $deliveryCompany = request()->post('delivery_company', '');
  310. $deliveryNo = request()->post('delivery_no', '');
  311. $deliveryCode = request()->post('delivery_code', '');
  312. if (!$id) {
  313. return ['code' => 1, 'msg' => '参数错误'];
  314. }
  315. $order = $this->model->find($id);
  316. if (!$order) {
  317. return ['code' => 1, 'msg' => '订单不存在'];
  318. }
  319. if ($order->status != 2) {
  320. return ['code' => 1, 'msg' => '订单状态不正确,只有已付款订单可以发货'];
  321. }
  322. if (!$deliveryNo) {
  323. return ['code' => 1, 'msg' => '请填写快递单号'];
  324. }
  325. $updateData = [
  326. 'status' => 3, // 已发货
  327. 'delivery_company' => $deliveryCompany,
  328. 'delivery_no' => $deliveryNo,
  329. 'delivery_code' => $deliveryCode,
  330. 'update_time' => time()
  331. ];
  332. $result = $this->model->where('id', $id)->update($updateData);
  333. if ($result) {
  334. ActionLogModel::setTitle("订单发货");
  335. ActionLogModel::record();
  336. RedisService::keyDel("caches:orders:*");
  337. return ['code' => 0, 'msg' => '发货成功'];
  338. }
  339. return ['code' => 1, 'msg' => '操作失败'];
  340. }
  341. /**
  342. * 订单完成(管理后台)
  343. */
  344. public function completeOrder()
  345. {
  346. $id = request()->post('id');
  347. if (!$id) {
  348. return ['code' => 1, 'msg' => '参数错误'];
  349. }
  350. $order = $this->model->find($id);
  351. if (!$order) {
  352. return ['code' => 1, 'msg' => '订单不存在'];
  353. }
  354. if ($order->status != 3) {
  355. return ['code' => 1, 'msg' => '订单状态不正确,只有已发货订单可以完成'];
  356. }
  357. // 调用用户端的订单完成方法,触发收益结算等业务逻辑
  358. $apiOrderService = \App\Services\Api\OrderService::make();
  359. $result = $apiOrderService->complete($order->user_id, $id);
  360. if ($result) {
  361. ActionLogModel::setTitle("订单完成");
  362. ActionLogModel::record();
  363. RedisService::keyDel("caches:orders:*");
  364. return ['code' => 0, 'msg' => '确认收货成功'];
  365. }
  366. // 获取错误信息
  367. $error = $apiOrderService->getError();
  368. return ['code' => 1, 'msg' => $error ?: '操作失败', 'error' => $error];
  369. }
  370. /**
  371. * 取消订单
  372. */
  373. public function settleOrder()
  374. {
  375. $id = request()->post('id');
  376. if (!$id) {
  377. return ['code' => 1, 'msg' => '参数错误'];
  378. }
  379. $cacheLockKey = "caches:orders:settle_".$id.'_lock';
  380. if(RedisService::get($cacheLockKey)){
  381. return ['code' => 1, 'msg' => '结算中'];
  382. }
  383. $order = $this->model->find($id);
  384. $orderNo = isset($order['order_no'])?$order['order_no']:'';
  385. $storeId = isset($order['store_id'])?$order['store_id']:0;
  386. $userId = isset($order['user_id'])?$order['user_id']:0;
  387. if (!$order) {
  388. return ['code' => 1, 'msg' => '订单不存在'];
  389. }
  390. if ($order->bonus_settle == 1) {
  391. return ['code' => 1, 'msg' => '佣金收益已结算'];
  392. }
  393. if ($order->status != 4) {
  394. return ['code' => 1, 'msg' => '订单未完成'];
  395. }
  396. RedisService::set($cacheLockKey, $order, rand(10,20));
  397. DB::beginTransaction();
  398. // 结算商家收益
  399. $result = SettleService::make()->storeBonus($storeId, $order['bonus'], $order);
  400. if ($result < 0) {
  401. DB::rollBack();
  402. $this->error = SettleService::make()->getError();
  403. RedisService::clear($cacheLockKey);
  404. \App\Services\Api\OrderService::make()->saveLog("caches:settle:{$orderNo}:store_{$storeId}_error",SettleService::make()->getError());
  405. return false;
  406. }
  407. \App\Services\Api\OrderService::make()->saveLog("caches:settle:{$orderNo}:store_{$storeId}",['msg'=>SettleService::make()->getError(),'result'=>$result]);
  408. // 代理佣金结算
  409. $result = SettleService::make()->agentBonus($userId, $order['rec_bonus'], $order, $order['rec_bonus_id']);
  410. if ($result < 0) {
  411. DB::rollBack();
  412. $this->error = SettleService::make()->getError();
  413. RedisService::clear($cacheLockKey);
  414. \App\Services\Api\OrderService::make()->saveLog("caches:settle:{$orderNo}:agent_{$userId}_error",SettleService::make()->getError());
  415. return false;
  416. }
  417. \App\Services\Api\OrderService::make()->saveLog("caches:settle:{$orderNo}:agent_{$userId}",['msg'=>SettleService::make()->getError(),'result'=>$result]);
  418. DB::commit();
  419. ActionLogModel::setTitle("订单结算");
  420. ActionLogModel::record();
  421. RedisService::keyDel("caches:orders:*");
  422. return ['code' => 0, 'msg' => '订单结算'];
  423. }
  424. /**
  425. * 取消订单
  426. */
  427. public function cancelOrder()
  428. {
  429. $id = request()->post('id');
  430. $cancelReason = request()->post('cancel_reason', '');
  431. if (!$id) {
  432. return ['code' => 1, 'msg' => '参数错误'];
  433. }
  434. $order = $this->model->find($id);
  435. if (!$order) {
  436. return ['code' => 1, 'msg' => '订单不存在'];
  437. }
  438. if ($order->status != 1) {
  439. return ['code' => 1, 'msg' => '只有待付款订单可以取消'];
  440. }
  441. $updateData = [
  442. 'mark' => 0, // 标记为删除
  443. 'update_time' => time()
  444. ];
  445. $result = $this->model->where('id', $id)->update($updateData);
  446. if ($result) {
  447. ActionLogModel::setTitle("取消订单");
  448. ActionLogModel::record();
  449. RedisService::keyDel("caches:orders:*");
  450. return ['code' => 0, 'msg' => '订单已取消'];
  451. }
  452. return ['code' => 1, 'msg' => '操作失败'];
  453. }
  454. /**
  455. * 申请退款
  456. */
  457. public function applyRefund()
  458. {
  459. $id = request()->post('id');
  460. $afterType = request()->post('after_type', 2); // 默认退款
  461. $afterRealname = request()->post('after_realname', '');
  462. $afterPhone = request()->post('after_phone', '');
  463. $afterRemark = request()->post('after_remark', '');
  464. if (!$id) {
  465. return ['code' => 1, 'msg' => '参数错误'];
  466. }
  467. if (!$afterRealname) {
  468. return ['code' => 1, 'msg' => '请填写联系人姓名'];
  469. }
  470. if (!$afterPhone) {
  471. return ['code' => 1, 'msg' => '请填写联系电话'];
  472. }
  473. if (!$afterRemark) {
  474. return ['code' => 1, 'msg' => '请填写退款原因'];
  475. }
  476. $order = $this->model->find($id);
  477. if (!$order) {
  478. return ['code' => 1, 'msg' => '订单不存在'];
  479. }
  480. // 只有已付款、已发货、已完成的订单可以申请退款
  481. if (!in_array($order->status, [2, 3, 4])) {
  482. return ['code' => 1, 'msg' => '该订单状态不允许申请退款'];
  483. }
  484. if ($order->refund_status != 0) {
  485. return ['code' => 1, 'msg' => '该订单已申请过退款'];
  486. }
  487. $updateData = [
  488. 'refund_status' => 3, // 待审核
  489. 'after_type' => $afterType, // 1-售后,2-退款
  490. 'after_realname' => $afterRealname,
  491. 'after_phone' => $afterPhone,
  492. 'after_remark' => $afterRemark,
  493. 'update_time' => time()
  494. ];
  495. $result = $this->model->where('id', $id)->update($updateData);
  496. if ($result) {
  497. $typeText = $afterType == 1 ? '售后' : '退款';
  498. ActionLogModel::setTitle("申请{$typeText}");
  499. ActionLogModel::record();
  500. RedisService::keyDel("caches:orders:*");
  501. return ['code' => 0, 'msg' => "{$typeText}申请已提交"];
  502. }
  503. return ['code' => 1, 'msg' => '操作失败'];
  504. }
  505. /**
  506. * 同意退款(审核通过,状态变为已审核)
  507. */
  508. public function agreeRefund()
  509. {
  510. $id = request()->post('id');
  511. $refundRemark = request()->post('refund_remark', '');
  512. if (!$id) {
  513. return ['code' => 1, 'msg' => '参数错误'];
  514. }
  515. $order = $this->model->find($id);
  516. if (!$order) {
  517. return ['code' => 1, 'msg' => '订单不存在'];
  518. }
  519. if ($order->refund_status != 3) {
  520. return ['code' => 1, 'msg' => '该订单未申请退款或已处理'];
  521. }
  522. $updateData = [
  523. 'refund_status' => 2, // 已审核(待确认退款)
  524. 'refund_remark' => $refundRemark ?: '退款申请已通过,待确认退款',
  525. 'update_time' => time()
  526. ];
  527. $result = $this->model->where('id', $id)->update($updateData);
  528. if ($result) {
  529. ActionLogModel::setTitle("同意退款");
  530. ActionLogModel::record();
  531. RedisService::keyDel("caches:orders:*");
  532. return ['code' => 0, 'msg' => '已同意退款,请确认退款'];
  533. }
  534. return ['code' => 1, 'msg' => '操作失败'];
  535. }
  536. /**
  537. * 确认退款(最终完成退款)
  538. */
  539. public function confirmRefund()
  540. {
  541. $id = request()->post('id');
  542. $refundAmount = request()->post('refund_amount', 0);
  543. if (!$id) {
  544. return ['code' => 1, 'msg' => '参数错误'];
  545. }
  546. if ($refundAmount <= 0) {
  547. return ['code' => 1, 'msg' => '请输入退款金额'];
  548. }
  549. $order = $this->model->find($id);
  550. if (!$order) {
  551. return ['code' => 1, 'msg' => '订单不存在'];
  552. }
  553. // 允许待审核(3)和已审核(2)状态的订单进行退款
  554. if (!in_array($order->refund_status, [2, 3])) {
  555. return ['code' => 1, 'msg' => '该订单状态不允许退款'];
  556. }
  557. if ($refundAmount > $order->pay_total) {
  558. return ['code' => 1, 'msg' => '退款金额不能大于订单金额'];
  559. }
  560. // 使用事务
  561. DB::beginTransaction();
  562. try {
  563. // 调用支付服务退款
  564. $paymentService = \App\Services\PaymentService::make();
  565. $refundData = [
  566. 'money' => $refundAmount,
  567. 'pay_type' => $order->pay_type,
  568. 'order_no' => $order->order_no,
  569. 'out_trade_no' => $order->out_trade_no,
  570. 'transaction_id' => $order->transaction_id,
  571. 'remark' => '订单退款'
  572. ];
  573. $refundResult = $paymentService->refund($refundData, 'store');
  574. if (!$refundResult) {
  575. DB::rollBack();
  576. return ['code' => 1, 'msg' => '退款失败:' . $paymentService->getError() ?: '退款失败'];
  577. }
  578. // 更新订单状态
  579. $updateData = [
  580. 'refund_status' => 1, // 已退款
  581. 'refund_amount' => $refundAmount,
  582. 'update_time' => time()
  583. ];
  584. $result = $this->model->where('id', $id)->update($updateData);
  585. if ($result) {
  586. DB::commit();
  587. ActionLogModel::setTitle("确认退款");
  588. ActionLogModel::record();
  589. RedisService::keyDel("caches:orders:*");
  590. return ['code' => 0, 'msg' => '退款成功'];
  591. }
  592. DB::rollBack();
  593. return ['code' => 1, 'msg' => '更新订单状态失败'];
  594. } catch (\Exception $e) {
  595. DB::rollBack();
  596. return ['code' => 1, 'msg' => '退款失败:' . $e->getMessage()];
  597. }
  598. }
  599. /**
  600. * 拒绝退款
  601. */
  602. public function rejectRefund()
  603. {
  604. $id = request()->post('id');
  605. $refundRemark = request()->post('refund_remark', '');
  606. if (!$id) {
  607. return ['code' => 1, 'msg' => '参数错误'];
  608. }
  609. if (!$refundRemark) {
  610. return ['code' => 1, 'msg' => '请填写拒绝原因'];
  611. }
  612. $order = $this->model->find($id);
  613. if (!$order) {
  614. return ['code' => 1, 'msg' => '订单不存在'];
  615. }
  616. if ($order->refund_status != 3) {
  617. return ['code' => 1, 'msg' => '该订单未申请退款或已处理'];
  618. }
  619. $updateData = [
  620. 'refund_status' => 4, // 审核驳回
  621. 'refund_remark' => $refundRemark,
  622. 'update_time' => time()
  623. ];
  624. $result = $this->model->where('id', $id)->update($updateData);
  625. if ($result) {
  626. ActionLogModel::setTitle("拒绝退款");
  627. ActionLogModel::record();
  628. RedisService::keyDel("caches:orders:*");
  629. return ['code' => 0, 'msg' => '已拒绝退款'];
  630. }
  631. return ['code' => 1, 'msg' => '操作失败'];
  632. }
  633. /**
  634. * 订单统计
  635. * @param int $storeId 商户ID,0表示平台管理员查看全部数据
  636. */
  637. public function getStatistics($storeId = 0)
  638. {
  639. // 总订单数
  640. $params = request()->all();
  641. $userId = isset($params['user_id'])?$params['user_id']:0;
  642. $where = ['user_id'=>$userId,'mark'=>1];
  643. if($userId<=0){
  644. unset($where['user_id']);
  645. }
  646. $total = $this->model->where($where)
  647. ->when($storeId > 0, function ($query) use ($storeId) {
  648. return $query->where('store_id', $storeId);
  649. })
  650. ->count();
  651. // 总交易额(已完成订单)
  652. $totalAmount = $this->model->where($where)
  653. ->where('status', 4)
  654. ->when($storeId > 0, function ($query) use ($storeId) {
  655. return $query->where('store_id', $storeId);
  656. })
  657. ->sum('pay_total');
  658. // 待处理订单(待付款 + 已付款)
  659. $pending = $this->model->where($where)
  660. ->whereIn('status', [1, 2])
  661. ->when($storeId > 0, function ($query) use ($storeId) {
  662. return $query->where('store_id', $storeId);
  663. })
  664. ->count();
  665. // 待退款订单
  666. $refunding = $this->model->where($where)
  667. ->where('refund_status', 3)
  668. ->when($storeId > 0, function ($query) use ($storeId) {
  669. return $query->where('store_id', $storeId);
  670. })
  671. ->count();
  672. return [
  673. 'code' => 0,
  674. 'msg' => '操作成功',
  675. 'data' => [
  676. 'total' => $total,
  677. 'totalAmount' => number_format($totalAmount, 2, '.', ''),
  678. 'pending' => $pending,
  679. 'refunding' => $refunding
  680. ]
  681. ];
  682. }
  683. /**
  684. * 导出订单数据
  685. */
  686. public function exportData($params)
  687. {
  688. $query = $this->model->where('mark', 1);
  689. // 店铺筛选
  690. if (isset($params['store_id']) && $params['store_id'] > 0) {
  691. $query->where('store_id', $params['store_id']);
  692. }
  693. // 用户筛选
  694. if (isset($params['user_id']) && $params['user_id'] > 0) {
  695. $query->where('user_id', $params['user_id']);
  696. }
  697. // 状态筛选
  698. if (isset($params['status']) && $params['status'] > 0) {
  699. $query->where('status', $params['status']);
  700. }
  701. // 售后类型筛选
  702. if (isset($params['after_type']) && $params['after_type'] > 0) {
  703. $query->where('after_type', $params['after_type']);
  704. }
  705. // 退款状态筛选
  706. if (isset($params['refund_status']) && $params['refund_status'] > 0) {
  707. $query->where('refund_status', $params['refund_status']);
  708. }
  709. // 关键词搜索
  710. if (isset($params['keyword']) && $params['keyword']) {
  711. $keyword = $params['keyword'];
  712. $query->where(function ($q) use ($keyword) {
  713. $q->where('order_no', 'like', '%' . $keyword . '%')
  714. ->orWhere('receiver_name', 'like', '%' . $keyword . '%')
  715. ->orWhere('receiver_mobile', 'like', '%' . $keyword . '%');
  716. });
  717. }
  718. $list = $query->with(['user', 'orderGoods', 'store'])
  719. ->orderBy('create_time', 'desc')
  720. ->limit(5000)
  721. ->get();
  722. if (!$list || $list->isEmpty()) {
  723. return response()->json(['code' => 1, 'msg' => '没有可导出的数据']);
  724. }
  725. // 状态映射
  726. $statusMap = [1 => '待付款', 2 => '已付款', 3 => '已发货', 4 => '已完成', 9 => '已取消'];
  727. $refundStatusMap = [0 => '无', 1 => '已退款', 2 => '已审核', 3 => '待审核'];
  728. // 构建导出数据
  729. $data = [];
  730. foreach ($list as $item) {
  731. $goodsNames = [];
  732. if ($item->orderGoods) {
  733. foreach ($item->orderGoods as $goods) {
  734. $goodsNames[] = $goods->goods_name . ' x' . $goods->num;
  735. }
  736. }
  737. $data[] = [
  738. $item->order_no,
  739. $item->user->nickname ?? '',
  740. $item->user->mobile ?? '',
  741. implode(';', $goodsNames),
  742. $item->total ?? 0,
  743. $item->pay_total ?? 0,
  744. $statusMap[$item->status] ?? '未知',
  745. $refundStatusMap[$item->refund_status] ?? '无',
  746. $item->receiver_name ?? '',
  747. $item->receiver_mobile ?? '',
  748. $item->receiver_address ?? '',
  749. $item->create_time ? date('Y-m-d H:i:s', strtotime($item->create_time)) : '',
  750. ];
  751. }
  752. $headings = ['订单号', '用户昵称', '用户手机', '商品信息', '订单金额', '实付金额', '订单状态', '退款状态', '收货人', '收货电话', '收货地址', '下单时间'];
  753. $export = new \App\Exports\Export($data, $headings, '订单列表');
  754. $filename = '订单列表_' . date('YmdHis') . '.xlsx';
  755. return \Maatwebsite\Excel\Facades\Excel::download($export, $filename);
  756. }
  757. }