OrderService.php 30 KB

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