Order.php 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603
  1. <?php
  2. namespace app\admin\controller\shop;
  3. use app\common\controller\Backend;
  4. use app\admin\model\shop\OrderElectronics;
  5. use app\common\Enum\OrderEnum;
  6. use app\common\Enum\GoodsEnum;
  7. use app\common\Enum\PayEnum;
  8. use app\common\Enum\ChannelEnum;
  9. use app\common\Enum\OrderActionEnum;
  10. use app\common\Service\Order\OrderActionService;
  11. use app\common\Service\Pay\PayService;
  12. use app\common\library\KdApiExpOrder;
  13. /**
  14. * 订单管理
  15. *
  16. * @icon fa fa-circle-o
  17. */
  18. class Order extends Backend
  19. {
  20. /**
  21. * Order模型对象
  22. * @var \app\admin\model\shop\Order
  23. */
  24. protected $model = null;
  25. protected $relationSearch = true;
  26. protected $searchFields = 'id,order_sn';
  27. public function _initialize()
  28. {
  29. parent::_initialize();
  30. $this->model = new \app\admin\model\shop\Order;
  31. // 视图赋值
  32. $this->view->assign("orderStatusList", OrderEnum::getOrderStatusList());
  33. $this->view->assign("statusList", $this->model->getStatusList());
  34. // $this->view->assign("payModeList", OrderEnum::getPayModeList());
  35. $this->view->assign("payTypeList", PayEnum::getPayMethodList());
  36. $this->view->assign("orderTypeList", OrderEnum::getOrderTypeList());
  37. $this->view->assign("deliveryTypeList", OrderEnum::getDeliveryTypeList());
  38. $this->view->assign("invoiceStatusList", OrderEnum::getInvoiceStatusList());
  39. // $this->view->assign("activityTypeList", OrderEnum::getActivityTypeList());
  40. $this->view->assign("actionTypeList", OrderActionEnum::getActionTypeList());
  41. $this->view->assign("saleStatusList", GoodsEnum::getSaleStatusMap());
  42. // 前端配置
  43. $this->assignconfig('orderStatusList', json_encode(OrderEnum::getOrderStatusList()));
  44. // $this->assignconfig('payModeList', json_encode(OrderEnum::getPayModeList()));
  45. $this->assignconfig('payTypeList', json_encode(PayEnum::getPayMethodList()));
  46. $this->assignconfig('statusList', json_encode($this->model->getStatusList()));
  47. $this->assignconfig('orderTypeList', json_encode(OrderEnum::getOrderTypeList()));
  48. $this->assignconfig('deliveryTypeList', json_encode(OrderEnum::getDeliveryTypeList()));
  49. $this->assignconfig('invoiceStatusList', json_encode(OrderEnum::getInvoiceStatusList()));
  50. // $this->assignconfig('activityTypeList', json_encode(OrderEnum::getActivityTypeList()));
  51. $this->assignconfig('actionTypeList', json_encode(OrderActionEnum::getActionTypeList()));
  52. $this->assignconfig('saleStatusList', json_encode(GoodsEnum::getSaleStatusMap()));
  53. }
  54. /**
  55. * 根据显示类型获取对应的订单状态列表
  56. * @param string $showType 显示类型
  57. * @return array 状态列表
  58. */
  59. public static function getStatusByShowType($showType)
  60. {
  61. $statusMap = [
  62. 'all' => [],
  63. 'wait_pay' => [OrderEnum::STATUS_CREATE],
  64. 'cancelled' => [OrderEnum::STATUS_CANCEL, OrderEnum::STATUS_AUTO_CANCEL, OrderEnum::STATUS_ADMIN_CANCEL],
  65. 'refund' => [OrderEnum::STATUS_REFUND, OrderEnum::STATUS_REFUND_CONFIRM, OrderEnum::STATUS_GROUPON_TIMEOUT],
  66. 'wait_ship' => [OrderEnum::STATUS_PAY],
  67. 'shipped' => [OrderEnum::STATUS_SHIP],
  68. 'wait_comment' => [OrderEnum::STATUS_CONFIRM, OrderEnum::STATUS_AUTO_CONFIRM],
  69. 'completed' => [OrderEnum::STATUS_COMMENT],
  70. ];
  71. return isset($statusMap[$showType]) ? $statusMap[$showType] : [];
  72. }
  73. /**
  74. * 获取订单状态筛选条件
  75. * @param string $showType 显示类型
  76. * @return array 筛选条件
  77. */
  78. public static function getStatusFilter($showType)
  79. {
  80. $statusList = self::getStatusByShowType($showType);
  81. if (empty($statusList)) {
  82. return [];
  83. }
  84. if (count($statusList) === 1) {
  85. return ['order_status' => $statusList[0]];
  86. }
  87. return ['order_status' => ['in', implode(',', $statusList)]];
  88. }
  89. /**
  90. * 默认生成的控制器所继承的父类中有index/add/edit/del/multi五个基础方法、destroy/restore/recyclebin三个回收站方法
  91. * 因此在当前控制器中可不用编写增删改查的代码,除非需要自己控制这部分逻辑
  92. * 需要将application/admin/library/traits/Backend.php中对应的方法复制到当前控制器,然后进行修改
  93. */
  94. /**
  95. * 查看
  96. */
  97. public function index()
  98. {
  99. //设置过滤方法
  100. $this->request->filter(['strip_tags', 'trim']);
  101. if ($this->request->isAjax()) {
  102. //如果发送的来源是Selectpage,则转发到Selectpage
  103. if ($this->request->request('keyField')) {
  104. return $this->selectpage();
  105. }
  106. list($where, $sort, $order, $offset, $limit, , $alias) = $this->buildparams();
  107. $a = reset($alias);
  108. $list = $this->model
  109. ->with(['OrderAddress','OrderGoods','User'])
  110. ->order('createtime desc')
  111. ->where($where)
  112. ->paginate($limit);
  113. $result = array("total" => $list->total(), "rows" => $list->items());
  114. return json($result);
  115. }
  116. return $this->view->fetch();
  117. }
  118. //发货单列表
  119. public function orderList()
  120. {
  121. $ids = $this->request->post('ids/a');
  122. if (empty($ids)) {
  123. $this->error('参数错误');
  124. }
  125. $orderList = $this->model->with(['User', 'OrderGoods'])->order('createtime desc')->where('id', 'IN', $ids)->select();
  126. foreach ($orderList as $index => $item) {
  127. if ($item->user) {
  128. $item->user->visible(['id', 'nickname', 'avatar']);
  129. }
  130. }
  131. $orderList = collection($orderList)->toArray();
  132. foreach ($orderList as $index => $item) {
  133. $nums = 0;
  134. foreach ($item['order_goods'] as $key => $goods) {
  135. if ($goods['salestate'] == 4 || $goods['salestate'] == 5) {
  136. unset($orderList[$index]['order_goods'][$key]);
  137. } else {
  138. $nums += $goods['nums'];
  139. }
  140. }
  141. $orderList[$index]['nums'] = $nums;
  142. }
  143. $this->success('获取成功', '', ['orderList' => $orderList]);
  144. }
  145. //订单详情
  146. public function detail()
  147. {
  148. $id = $this->request->param('ids');
  149. if (!$id) {
  150. $this->error('参数错误');
  151. }
  152. // 查询订单信息,包括关联的用户、商品、操作记录、收货地址、档案信息
  153. $row = $this->model
  154. ->field('o.*,sum(s.refund) refund')
  155. ->with([
  156. 'User' => function($query) {
  157. $query->field('id,username,nickname,avatar,email,mobile');
  158. },
  159. 'OrderGoods' => function($query) {
  160. $query->field('*');
  161. },
  162. 'OrderAddress' => function($query) {
  163. $query->field('*');
  164. },
  165. 'OrderProfile' => function($query) {
  166. $query->field('*');
  167. }
  168. ])
  169. ->where('o.id', $id)
  170. ->alias('o')
  171. ->join('shop_order_aftersales s', 'o.id=s.order_id and s.status=2 and s.type <> 3', 'LEFT')
  172. ->find();
  173. if (!$row) {
  174. $this->error('记录未找到');
  175. }
  176. // 转换为数组以便处理
  177. $rowData = $row->toArray();
  178. // 添加枚举文本转换
  179. $rowData['order_status_text'] = OrderEnum::getOrderStatusText($rowData['order_status']);
  180. $rowData['source_text'] = ChannelEnum::getChannelText($rowData['source'] ?? '');
  181. $rowData['type_text'] = $this->getTypeText($rowData['type']);
  182. $rowData['pay_type_text'] = $this->getPayTypeText($rowData['pay_type']);
  183. // $rowData['pay_mode_text'] = $this->getPayModeText($rowData['pay_mode']);
  184. $rowData['delivery_type_text'] = $this->getDeliveryTypeText($rowData['delivery_type']);
  185. if (!empty($rowData['invoice_status'])) {
  186. $rowData['invoice_status_text'] = $this->getInvoiceStatusText($rowData['invoice_status']);
  187. }
  188. // if (!empty($rowData['activity_type'])) {
  189. // $rowData['activity_type_text'] = $this->getActivityTypeText($rowData['activity_type']);
  190. // }
  191. // 处理订单商品的规格信息和售后状态文本
  192. if (!empty($rowData['order_goods'])) {
  193. $orderGoods = [];
  194. foreach ($rowData['order_goods'] as $index => $item) {
  195. // 格式化商品规格属性
  196. $item['goods_sku_attr_formatted'] = $this->formatGoodsSkuAttr($item['goods_sku_attr']);
  197. // 处理售后状态文本
  198. $item['sale_status_text'] = $this->getSaleStatusText($item['sale_status']);
  199. $orderGoods[] = $item;
  200. }
  201. $rowData['order_goods'] = $orderGoods;
  202. }
  203. // 使用 OrderActionService 获取订单操作记录
  204. $orderActions = OrderActionService::getActionTimeline($rowData['order_sn']);
  205. // 将操作记录添加到订单数据中
  206. $rowData['order_action'] = $orderActions;
  207. // 支付信息
  208. // 查询支付信息
  209. $payInfo = PayService::getPayInfo($rowData['id']);
  210. $rowData['pay_info'] = $payInfo;
  211. // 处理档案信息
  212. // echo "<pre>";
  213. // print_r($rowData);
  214. // die();
  215. if (!empty($rowData['order_profile'])) {
  216. $profile = $rowData['order_profile'];
  217. // // 处理体型选择数据
  218. // if (!empty($profile['body_types'])) {
  219. // $bodyTypes = json_decode($profile['body_types'], true);
  220. // $profile['body_types_formatted'] = is_array($bodyTypes) ? $bodyTypes : [];
  221. // }
  222. // // 处理AI报告内容
  223. // if (!empty($profile['ai_report_content'])) {
  224. // $aiReportContent = json_decode($profile['ai_report_content'], true);
  225. // $profile['ai_report_content_formatted'] = is_array($aiReportContent) ? $aiReportContent : [];
  226. // }
  227. // // 处理身体照片
  228. // if (!empty($profile['body_photos'])) {
  229. // $bodyPhotos = json_decode($profile['body_photos'], true);
  230. // $profile['body_photos_formatted'] = is_array($bodyPhotos) ? $bodyPhotos : [];
  231. // }
  232. $rowData['order_profile'] = $profile;
  233. }
  234. $config = get_addon_config('shop');
  235. $this->assignconfig('shop', $config);
  236. $this->view->assign('row', $rowData);
  237. return $this->view->fetch();
  238. }
  239. /**
  240. * 获取订单来源文本
  241. */
  242. private function getPlatformText($platform)
  243. {
  244. // 直接使用ChannelEnum获取渠道文本
  245. return ChannelEnum::getChannelText($platform);
  246. }
  247. /**
  248. * 获取订单类型文本
  249. */
  250. private function getTypeText($type)
  251. {
  252. return OrderEnum::getOrderTypeText($type);
  253. }
  254. /**
  255. * 获取支付方式文本
  256. */
  257. private function getPayTypeText($payType)
  258. {
  259. // 直接使用PayEnum获取支付方式文本
  260. return PayEnum::getPayMethodText($payType);
  261. }
  262. /**
  263. * 获取发货方式文本
  264. */
  265. private function getDeliveryTypeText($deliveryType)
  266. {
  267. return OrderEnum::getDeliveryTypeText($deliveryType);
  268. }
  269. /**
  270. * 获取发票状态文本
  271. */
  272. private function getInvoiceStatusText($invoiceStatus)
  273. {
  274. return OrderEnum::getInvoiceStatusText($invoiceStatus);
  275. }
  276. /**
  277. * 获取售后状态文本
  278. */
  279. private function getSaleStatusText($saleStatus)
  280. {
  281. return GoodsEnum::getSaleStatusText($saleStatus);
  282. }
  283. /**
  284. * 格式化商品规格属性
  285. */
  286. private function formatGoodsSkuAttr($goodsSkuAttr)
  287. {
  288. if (empty($goodsSkuAttr)) {
  289. return [];
  290. }
  291. // 尝试解析JSON格式的规格信息
  292. $decoded = json_decode($goodsSkuAttr, true);
  293. if (json_last_error() === JSON_ERROR_NONE && is_array($decoded)) {
  294. return $decoded;
  295. }
  296. // 如果不是JSON格式,直接返回原始字符串(兼容旧格式)
  297. return [
  298. [
  299. 'name' => '规格',
  300. 'value' => $goodsSkuAttr
  301. ]
  302. ];
  303. }
  304. //订单状态操作
  305. public function edit_status()
  306. {
  307. $order_status = $this->request->post('order_status');
  308. $pay_time = $this->request->post('pay_time');
  309. $order_id = $this->request->post('order_id');
  310. $order = $this->model->where('id', $order_id)->find();
  311. if (!$order) {
  312. $this->error('未找到订单记录');
  313. }
  314. //取消
  315. if ($order_status == OrderEnum::STATUS_CANCEL && $order->order_status == OrderEnum::STATUS_CREATE && !$order->pay_time) {
  316. $oldStatus = $order->order_status;
  317. $order->order_status = OrderEnum::STATUS_CANCEL;
  318. $order->cancel_time = time();
  319. $order->save();
  320. // 记录管理员操作
  321. OrderActionService::recordAdminAction(
  322. $order->order_sn,
  323. OrderActionEnum::ACTION_ADMIN_CANCEL,
  324. '管理员',
  325. '管理员取消订单',
  326. $this->auth->id ?? 0
  327. );
  328. $this->success('取消成功');
  329. }
  330. // 支付
  331. if ($pay_time && $order->order_status == OrderEnum::STATUS_CREATE && !$order->pay_time) {
  332. $oldStatus = $order->order_status;
  333. $order->order_status = OrderEnum::STATUS_PAY;
  334. $order->pay_type = 'system';
  335. $order->pay_amount = $order->amount;
  336. $order->pay_time = time();
  337. $order->save();
  338. // 记录管理员操作
  339. OrderActionService::recordAdminAction(
  340. $order->order_sn,
  341. OrderActionEnum::ACTION_PAY,
  342. '管理员',
  343. '管理员手动标记订单为已支付',
  344. $this->auth->id ?? 0
  345. );
  346. //发送通知
  347. //TemplateMsg::sendTempMsg(0, $order->order_sn);
  348. $this->success('操作成功');
  349. }
  350. //已完成
  351. if ($order_status == OrderEnum::STATUS_CONFIRM && $order->order_status == OrderEnum::STATUS_PAY && $order->pay_time) {
  352. $oldStatus = $order->order_status;
  353. $order->order_status = OrderEnum::STATUS_CONFIRM;
  354. $order->save();
  355. // 记录管理员操作
  356. OrderActionService::recordAdminAction(
  357. $order->order_sn,
  358. OrderActionEnum::ACTION_RECEIVE,
  359. '管理员',
  360. '管理员手动标记订单为已完成',
  361. $this->auth->id ?? 0
  362. );
  363. $this->success('操作成功');
  364. } elseif ($order->order_status == OrderEnum::STATUS_REFUND) {
  365. $this->error("请完成售后后再进行操作");
  366. }
  367. $this->error('没有权限操作');
  368. }
  369. //编辑订单信息【备注等】
  370. public function edit_info()
  371. {
  372. $id = $this->request->post('id');
  373. $field = $this->request->post('field');
  374. $value = $this->request->post('value');
  375. if (!in_array($field, ['memo'])) {
  376. $this->error('没有权限编辑');
  377. }
  378. $row = $this->model->with(['User'])->where('id', $id)->find();
  379. if (!$row) {
  380. $this->error('记录未找到');
  381. }
  382. $row->$field = $value;
  383. $row->save();
  384. $this->success('保存成功');
  385. }
  386. //发货
  387. public function deliver()
  388. {
  389. $expressname = $this->request->post('expressname');
  390. $expressno = $this->request->post('expressno');
  391. $order_id = $this->request->post('order_id');
  392. $type = $this->request->post('type');
  393. $order = $this->model->where('id', $order_id)->find();
  394. if (!$order) {
  395. $this->error('未找到订单记录');
  396. }
  397. //发货 / 修改快递信息
  398. if ($order->order_status == OrderEnum::STATUS_PAY && $type == 0) {
  399. $oldStatus = $order->order_status;
  400. $order->express_name = $expressname;
  401. $order->express_no = $expressno;
  402. $order->order_status = OrderEnum::STATUS_SHIP;
  403. $order->shipping_time = time();
  404. $order->save();
  405. // 记录管理员操作
  406. OrderActionService::recordAdminAction(
  407. $order->order_sn,
  408. OrderActionEnum::ACTION_SHIP,
  409. '管理员',
  410. '管理员发货,快递公司:' . $expressname . ',快递单号:' . $expressno,
  411. $this->auth->id ?? 0,
  412. [
  413. 'express_name' => $expressname,
  414. 'express_no' => $expressno,
  415. ]
  416. );
  417. $this->success('发货成功');
  418. } elseif ($type == 1) {
  419. $order->express_name = $expressname;
  420. $order->express_no = $expressno;
  421. $order->save();
  422. $this->success('修改成功');
  423. } elseif ($order->order_status == OrderEnum::STATUS_REFUND) {
  424. $this->error("请完成售后后再进行操作");
  425. }
  426. $this->error('没有权限操作');
  427. }
  428. //电子面单【单独】
  429. public function electronics()
  430. {
  431. $order_id = $this->request->param('order_id');
  432. $row = $this->model->field('o.id,oe.print_template')
  433. ->where('o.id', $order_id)
  434. ->alias('o')
  435. ->join('shop_order_electronics oe', 'oe.order_sn=o.order_sn and oe.status=0', 'LEFT')
  436. ->find();
  437. if ($row && !empty($row['print_template'])) {
  438. $this->success('获取成功', '', ['PrintTemplate' => $row->print_template]);
  439. }
  440. $res = [];
  441. $electronics_id = $this->request->param('electronics_id');
  442. try {
  443. $res = \addons\shop\library\KdApiExpOrder::create($order_id, $electronics_id);
  444. } catch (\Exception $e) {
  445. $this->error($e->getMessage());
  446. }
  447. if (!isset($res['Success']) || !$res['Success']) {
  448. $msg = isset($res['Reason']) ? $res['Reason'] : '请求失败';
  449. $this->error($msg);
  450. }
  451. //成功
  452. $this->success('开始打印', '', $res);
  453. }
  454. //批量打印
  455. public function prints()
  456. {
  457. $ids = $this->request->param('ids');
  458. if (empty($ids)) {
  459. $this->error('打印参数错误');
  460. }
  461. $order_ids = explode('_', $ids);
  462. if ($this->request->isPost()) {
  463. $electronics_id = $this->request->post('electronics_id');
  464. $param = [];
  465. //是否已获取
  466. $list = $this->model->field('o.id,oe.print_template')
  467. ->where('o.id', 'IN', $order_ids)
  468. ->alias('o')
  469. ->join('shop_order_electronics oe', 'oe.order_sn=o.order_sn and oe.status=0', 'LEFT')
  470. ->select();
  471. $has_ids = [];
  472. //获取过的
  473. if ($list) {
  474. foreach ($list as $item) {
  475. if (!empty($item['print_template'])) {
  476. $param[] = [
  477. 'PrintTemplate' => $item['print_template'],
  478. 'Success' => true
  479. ];
  480. $has_ids[] = $item['id'];
  481. }
  482. }
  483. }
  484. //剩余未获取的
  485. try {
  486. foreach (array_diff($order_ids, $has_ids) as $order_id) {
  487. $res = \addons\shop\library\KdApiExpOrder::create($order_id, $electronics_id);
  488. if ($res) {
  489. $param[] = $res;
  490. }
  491. }
  492. } catch (\Exception $e) {
  493. $this->error($e->getMessage());
  494. }
  495. $this->success('操作成功', '', $param);
  496. }
  497. $config = get_addon_config('shop');
  498. $this->assignconfig('shop', $config);
  499. $this->assignconfig('order_ids', $order_ids);
  500. $order = $this->model->with(['OrderGoods', 'OrderAddress'])->where('id', 'IN', $order_ids)->select();
  501. // 处理规格信息格式化
  502. $processedOrder = [];
  503. foreach ($order as $orderItem) {
  504. $orderData = $orderItem->toArray();
  505. if (isset($orderData['order_goods']) && $orderData['order_goods']) {
  506. foreach ($orderData['order_goods'] as $index => $goodsItem) {
  507. $orderData['order_goods'][$index]['goods_sku_attr_formatted'] = $this->formatGoodsSkuAttr($goodsItem['goods_sku_attr']);
  508. }
  509. }
  510. $processedOrder[] = $orderData;
  511. }
  512. $order = $processedOrder;
  513. $this->view->assign('order', $order);
  514. return $this->view->fetch();
  515. }
  516. //取消电子面单
  517. public function cancel_electronics()
  518. {
  519. $oe_id = $this->request->param('oe_id');
  520. $row = OrderElectronics::get($oe_id);
  521. if ($row['status'] == 1) {
  522. $this->error('电子面单已取消');
  523. }
  524. $res = \app\common\library\KdApiExpOrder::cancel($row);
  525. if (isset($res['Success']) && $res['Success']) {
  526. $row->status = 1;
  527. $row->save();
  528. $this->success('取消成功', '', $res);
  529. }
  530. $msg = isset($res['Reason']) ? $res['Reason'] : '取消失败';
  531. $this->error($msg);
  532. }
  533. }