OrderService.php 30 KB

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