OrderService.php 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892
  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. RedisService::set($cacheLockKey, $order, rand(10,20));
  394. DB::beginTransaction();
  395. // 结算商家收益
  396. $result = SettleService::make()->storeBonus($storeId, $order['bonus'], $order);
  397. if ($result < 0) {
  398. DB::rollBack();
  399. $this->error = SettleService::make()->getError();
  400. RedisService::clear($cacheLockKey);
  401. \App\Services\Api\OrderService::make()->saveLog("caches:settle:{$orderNo}:store_{$storeId}_error",SettleService::make()->getError());
  402. return false;
  403. }
  404. \App\Services\Api\OrderService::make()->saveLog("caches:settle:{$orderNo}:store_{$storeId}",$result);
  405. // 代理佣金结算
  406. $result = SettleService::make()->agentBonus($userId, $order['rec_bonus'], $order, $order['rec_bonus_id']);
  407. if ($result < 0) {
  408. DB::rollBack();
  409. $this->error = SettleService::make()->getError();
  410. RedisService::clear($cacheLockKey);
  411. \App\Services\Api\OrderService::make()->saveLog("caches:settle:{$orderNo}:agent_{$userId}_error",SettleService::make()->getError());
  412. return false;
  413. }
  414. \App\Services\Api\OrderService::make()->saveLog("caches:settle:{$orderNo}:agent_{$userId}",$result);
  415. DB::commit();
  416. ActionLogModel::setTitle("订单结算");
  417. ActionLogModel::record();
  418. RedisService::keyDel("caches:orders:*");
  419. return ['code' => 0, 'msg' => '订单结算'];
  420. }
  421. /**
  422. * 取消订单
  423. */
  424. public function cancelOrder()
  425. {
  426. $id = request()->post('id');
  427. $cancelReason = request()->post('cancel_reason', '');
  428. if (!$id) {
  429. return ['code' => 1, 'msg' => '参数错误'];
  430. }
  431. $order = $this->model->find($id);
  432. if (!$order) {
  433. return ['code' => 1, 'msg' => '订单不存在'];
  434. }
  435. if ($order->status != 1) {
  436. return ['code' => 1, 'msg' => '只有待付款订单可以取消'];
  437. }
  438. $updateData = [
  439. 'mark' => 0, // 标记为删除
  440. 'update_time' => time()
  441. ];
  442. $result = $this->model->where('id', $id)->update($updateData);
  443. if ($result) {
  444. ActionLogModel::setTitle("取消订单");
  445. ActionLogModel::record();
  446. RedisService::keyDel("caches:orders:*");
  447. return ['code' => 0, 'msg' => '订单已取消'];
  448. }
  449. return ['code' => 1, 'msg' => '操作失败'];
  450. }
  451. /**
  452. * 申请退款
  453. */
  454. public function applyRefund()
  455. {
  456. $id = request()->post('id');
  457. $afterType = request()->post('after_type', 2); // 默认退款
  458. $afterRealname = request()->post('after_realname', '');
  459. $afterPhone = request()->post('after_phone', '');
  460. $afterRemark = request()->post('after_remark', '');
  461. if (!$id) {
  462. return ['code' => 1, 'msg' => '参数错误'];
  463. }
  464. if (!$afterRealname) {
  465. return ['code' => 1, 'msg' => '请填写联系人姓名'];
  466. }
  467. if (!$afterPhone) {
  468. return ['code' => 1, 'msg' => '请填写联系电话'];
  469. }
  470. if (!$afterRemark) {
  471. return ['code' => 1, 'msg' => '请填写退款原因'];
  472. }
  473. $order = $this->model->find($id);
  474. if (!$order) {
  475. return ['code' => 1, 'msg' => '订单不存在'];
  476. }
  477. // 只有已付款、已发货、已完成的订单可以申请退款
  478. if (!in_array($order->status, [2, 3, 4])) {
  479. return ['code' => 1, 'msg' => '该订单状态不允许申请退款'];
  480. }
  481. if ($order->refund_status != 0) {
  482. return ['code' => 1, 'msg' => '该订单已申请过退款'];
  483. }
  484. $updateData = [
  485. 'refund_status' => 3, // 待审核
  486. 'after_type' => $afterType, // 1-售后,2-退款
  487. 'after_realname' => $afterRealname,
  488. 'after_phone' => $afterPhone,
  489. 'after_remark' => $afterRemark,
  490. 'update_time' => time()
  491. ];
  492. $result = $this->model->where('id', $id)->update($updateData);
  493. if ($result) {
  494. $typeText = $afterType == 1 ? '售后' : '退款';
  495. ActionLogModel::setTitle("申请{$typeText}");
  496. ActionLogModel::record();
  497. RedisService::keyDel("caches:orders:*");
  498. return ['code' => 0, 'msg' => "{$typeText}申请已提交"];
  499. }
  500. return ['code' => 1, 'msg' => '操作失败'];
  501. }
  502. /**
  503. * 同意退款(审核通过,状态变为已审核)
  504. */
  505. public function agreeRefund()
  506. {
  507. $id = request()->post('id');
  508. $refundRemark = request()->post('refund_remark', '');
  509. if (!$id) {
  510. return ['code' => 1, 'msg' => '参数错误'];
  511. }
  512. $order = $this->model->find($id);
  513. if (!$order) {
  514. return ['code' => 1, 'msg' => '订单不存在'];
  515. }
  516. if ($order->refund_status != 3) {
  517. return ['code' => 1, 'msg' => '该订单未申请退款或已处理'];
  518. }
  519. $updateData = [
  520. 'refund_status' => 2, // 已审核(待确认退款)
  521. 'refund_remark' => $refundRemark ?: '退款申请已通过,待确认退款',
  522. 'update_time' => time()
  523. ];
  524. $result = $this->model->where('id', $id)->update($updateData);
  525. if ($result) {
  526. ActionLogModel::setTitle("同意退款");
  527. ActionLogModel::record();
  528. RedisService::keyDel("caches:orders:*");
  529. return ['code' => 0, 'msg' => '已同意退款,请确认退款'];
  530. }
  531. return ['code' => 1, 'msg' => '操作失败'];
  532. }
  533. /**
  534. * 确认退款(最终完成退款)
  535. */
  536. public function confirmRefund()
  537. {
  538. $id = request()->post('id');
  539. $refundAmount = request()->post('refund_amount', 0);
  540. if (!$id) {
  541. return ['code' => 1, 'msg' => '参数错误'];
  542. }
  543. if ($refundAmount <= 0) {
  544. return ['code' => 1, 'msg' => '请输入退款金额'];
  545. }
  546. $order = $this->model->find($id);
  547. if (!$order) {
  548. return ['code' => 1, 'msg' => '订单不存在'];
  549. }
  550. // 允许待审核(3)和已审核(2)状态的订单进行退款
  551. if (!in_array($order->refund_status, [2, 3])) {
  552. return ['code' => 1, 'msg' => '该订单状态不允许退款'];
  553. }
  554. if ($refundAmount > $order->pay_total) {
  555. return ['code' => 1, 'msg' => '退款金额不能大于订单金额'];
  556. }
  557. // 使用事务
  558. DB::beginTransaction();
  559. try {
  560. // 调用支付服务退款
  561. $paymentService = \App\Services\PaymentService::make();
  562. $refundData = [
  563. 'money' => $refundAmount,
  564. 'pay_type' => $order->pay_type,
  565. 'order_no' => $order->order_no,
  566. 'out_trade_no' => $order->out_trade_no,
  567. 'transaction_id' => $order->transaction_id,
  568. 'remark' => '订单退款'
  569. ];
  570. $refundResult = $paymentService->refund($refundData, 'store');
  571. if (!$refundResult) {
  572. DB::rollBack();
  573. return ['code' => 1, 'msg' => '退款失败:' . $paymentService->getError() ?: '退款失败'];
  574. }
  575. // 更新订单状态
  576. $updateData = [
  577. 'refund_status' => 1, // 已退款
  578. 'refund_amount' => $refundAmount,
  579. 'update_time' => time()
  580. ];
  581. $result = $this->model->where('id', $id)->update($updateData);
  582. if ($result) {
  583. DB::commit();
  584. ActionLogModel::setTitle("确认退款");
  585. ActionLogModel::record();
  586. RedisService::keyDel("caches:orders:*");
  587. return ['code' => 0, 'msg' => '退款成功'];
  588. }
  589. DB::rollBack();
  590. return ['code' => 1, 'msg' => '更新订单状态失败'];
  591. } catch (\Exception $e) {
  592. DB::rollBack();
  593. return ['code' => 1, 'msg' => '退款失败:' . $e->getMessage()];
  594. }
  595. }
  596. /**
  597. * 拒绝退款
  598. */
  599. public function rejectRefund()
  600. {
  601. $id = request()->post('id');
  602. $refundRemark = request()->post('refund_remark', '');
  603. if (!$id) {
  604. return ['code' => 1, 'msg' => '参数错误'];
  605. }
  606. if (!$refundRemark) {
  607. return ['code' => 1, 'msg' => '请填写拒绝原因'];
  608. }
  609. $order = $this->model->find($id);
  610. if (!$order) {
  611. return ['code' => 1, 'msg' => '订单不存在'];
  612. }
  613. if ($order->refund_status != 3) {
  614. return ['code' => 1, 'msg' => '该订单未申请退款或已处理'];
  615. }
  616. $updateData = [
  617. 'refund_status' => 4, // 审核驳回
  618. 'refund_remark' => $refundRemark,
  619. 'update_time' => time()
  620. ];
  621. $result = $this->model->where('id', $id)->update($updateData);
  622. if ($result) {
  623. ActionLogModel::setTitle("拒绝退款");
  624. ActionLogModel::record();
  625. RedisService::keyDel("caches:orders:*");
  626. return ['code' => 0, 'msg' => '已拒绝退款'];
  627. }
  628. return ['code' => 1, 'msg' => '操作失败'];
  629. }
  630. /**
  631. * 订单统计
  632. * @param int $storeId 商户ID,0表示平台管理员查看全部数据
  633. */
  634. public function getStatistics($storeId = 0)
  635. {
  636. // 总订单数
  637. $params = request()->all();
  638. $userId = isset($params['user_id'])?$params['user_id']:0;
  639. $where = ['user_id'=>$userId,'mark'=>1];
  640. if($userId<=0){
  641. unset($where['user_id']);
  642. }
  643. $total = $this->model->where($where)
  644. ->when($storeId > 0, function ($query) use ($storeId) {
  645. return $query->where('store_id', $storeId);
  646. })
  647. ->count();
  648. // 总交易额(已完成订单)
  649. $totalAmount = $this->model->where($where)
  650. ->where('status', 4)
  651. ->when($storeId > 0, function ($query) use ($storeId) {
  652. return $query->where('store_id', $storeId);
  653. })
  654. ->sum('pay_total');
  655. // 待处理订单(待付款 + 已付款)
  656. $pending = $this->model->where($where)
  657. ->whereIn('status', [1, 2])
  658. ->when($storeId > 0, function ($query) use ($storeId) {
  659. return $query->where('store_id', $storeId);
  660. })
  661. ->count();
  662. // 待退款订单
  663. $refunding = $this->model->where($where)
  664. ->where('refund_status', 3)
  665. ->when($storeId > 0, function ($query) use ($storeId) {
  666. return $query->where('store_id', $storeId);
  667. })
  668. ->count();
  669. return [
  670. 'code' => 0,
  671. 'msg' => '操作成功',
  672. 'data' => [
  673. 'total' => $total,
  674. 'totalAmount' => number_format($totalAmount, 2, '.', ''),
  675. 'pending' => $pending,
  676. 'refunding' => $refunding
  677. ]
  678. ];
  679. }
  680. /**
  681. * 导出订单数据
  682. */
  683. public function exportData($params)
  684. {
  685. $query = $this->model->where('mark', 1);
  686. // 店铺筛选
  687. if (isset($params['store_id']) && $params['store_id'] > 0) {
  688. $query->where('store_id', $params['store_id']);
  689. }
  690. // 用户筛选
  691. if (isset($params['user_id']) && $params['user_id'] > 0) {
  692. $query->where('user_id', $params['user_id']);
  693. }
  694. // 状态筛选
  695. if (isset($params['status']) && $params['status'] > 0) {
  696. $query->where('status', $params['status']);
  697. }
  698. // 售后类型筛选
  699. if (isset($params['after_type']) && $params['after_type'] > 0) {
  700. $query->where('after_type', $params['after_type']);
  701. }
  702. // 退款状态筛选
  703. if (isset($params['refund_status']) && $params['refund_status'] > 0) {
  704. $query->where('refund_status', $params['refund_status']);
  705. }
  706. // 关键词搜索
  707. if (isset($params['keyword']) && $params['keyword']) {
  708. $keyword = $params['keyword'];
  709. $query->where(function ($q) use ($keyword) {
  710. $q->where('order_no', 'like', '%' . $keyword . '%')
  711. ->orWhere('receiver_name', 'like', '%' . $keyword . '%')
  712. ->orWhere('receiver_mobile', 'like', '%' . $keyword . '%');
  713. });
  714. }
  715. $list = $query->with(['user', 'orderGoods', 'store'])
  716. ->orderBy('create_time', 'desc')
  717. ->limit(5000)
  718. ->get();
  719. if (!$list || $list->isEmpty()) {
  720. return response()->json(['code' => 1, 'msg' => '没有可导出的数据']);
  721. }
  722. // 状态映射
  723. $statusMap = [1 => '待付款', 2 => '已付款', 3 => '已发货', 4 => '已完成', 9 => '已取消'];
  724. $refundStatusMap = [0 => '无', 1 => '已退款', 2 => '已审核', 3 => '待审核'];
  725. // 构建导出数据
  726. $data = [];
  727. foreach ($list as $item) {
  728. $goodsNames = [];
  729. if ($item->orderGoods) {
  730. foreach ($item->orderGoods as $goods) {
  731. $goodsNames[] = $goods->goods_name . ' x' . $goods->num;
  732. }
  733. }
  734. $data[] = [
  735. $item->order_no,
  736. $item->user->nickname ?? '',
  737. $item->user->mobile ?? '',
  738. implode(';', $goodsNames),
  739. $item->total ?? 0,
  740. $item->pay_total ?? 0,
  741. $statusMap[$item->status] ?? '未知',
  742. $refundStatusMap[$item->refund_status] ?? '无',
  743. $item->receiver_name ?? '',
  744. $item->receiver_mobile ?? '',
  745. $item->receiver_address ?? '',
  746. $item->create_time ? date('Y-m-d H:i:s', strtotime($item->create_time)) : '',
  747. ];
  748. }
  749. $headings = ['订单号', '用户昵称', '用户手机', '商品信息', '订单金额', '实付金额', '订单状态', '退款状态', '收货人', '收货电话', '收货地址', '下单时间'];
  750. $export = new \App\Exports\Export($data, $headings, '订单列表');
  751. $filename = '订单列表_' . date('YmdHis') . '.xlsx';
  752. return \Maatwebsite\Excel\Facades\Excel::download($export, $filename);
  753. }
  754. }