OrderService.php 31 KB

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