Order.php 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449
  1. <?php
  2. namespace app\api\controller;
  3. use app\common\model\UserCoupon;
  4. use app\common\model\Carts;
  5. use app\common\model\Order as OrderModel;
  6. use app\common\model\Address;
  7. use app\common\model\Third;
  8. use app\common\model\OrderAction;
  9. use app\common\model\OrderGoods;
  10. use app\common\library\KdApiExpOrder;
  11. use think\Db;
  12. use app\common\Service\OrderService;
  13. use app\common\Service\ParentOrderService;
  14. use app\common\Enum\OrderEnum;
  15. use app\common\Service\CartService;
  16. /**
  17. * 订单接口
  18. */
  19. class Order extends Base
  20. {
  21. protected $noNeedLogin = [];
  22. public function __construct()
  23. {
  24. parent::__construct();
  25. }
  26. //计算邮费,判断商品 - 支持购物车和商品规格两种模式
  27. public function calculate()
  28. {
  29. // 验证请求参数
  30. $validate = new \app\api\validate\Order();
  31. $postData = $this->request->post();
  32. $postData['calculate_data'] = '1'; // 添加触发自定义验证的字段
  33. if (!$validate->scene('calculate')->check($postData)) {
  34. $this->error($validate->getError());
  35. }
  36. $userId = $this->auth->id;
  37. $config = get_addon_config('shop');
  38. $address_id = $postData['address_id'] ?? 0; // 地址id
  39. $user_coupon_id = $postData['user_coupon_id'] ?? 0; // 优惠券
  40. $cart_ids = $postData['cart_ids'] ?? []; // 购物车ID数组
  41. $goods_list = $postData['goods_list'] ?? []; // 商品列表
  42. $address = Address::get($address_id);
  43. $area_id = !empty($address) ? $address->area_id : 0;
  44. try {
  45. // 自动判断数据源类型并获取标准化的商品列表
  46. if (!empty($cart_ids) && !empty($goods_list)) {
  47. // 结算页有加减数量,需同步更新购物车
  48. CartService::updateCartByGoodsList($cart_ids, $goods_list, $userId);
  49. // goods_list 直接参与后续计算
  50. } elseif (!empty($cart_ids)) {
  51. $goods_list = CartService::convertCartToGoodsList($cart_ids, $userId);
  52. } elseif (empty($goods_list)) {
  53. throw new \Exception("请提供购物车ID或商品列表");
  54. }
  55. // 统一调用计算方法
  56. $result = OrderService::calculateOrder($goods_list, $userId, $area_id, $user_coupon_id);
  57. $orderItem = $result['orderItem'];
  58. $goodsList = $result['goodsList'];
  59. $orderInfo = $result['orderInfo'];
  60. $userCoupon = $result['userCoupon'];
  61. if (empty($goodsList)) {
  62. throw new \Exception("未找到商品");
  63. }
  64. } catch (\Exception $e) {
  65. $this->error($e->getMessage());
  66. }
  67. // 处理商品数据
  68. foreach ($goodsList as $item) {
  69. //$item->category_id = $item->goods->category_id;
  70. $item->brand_id = $item->goods->brand_id;
  71. $item->goods->visible(explode(',', 'id,title,image,price,marketprice'));
  72. }
  73. // 获取我的可以使用的优惠券
  74. $goods_ids = array_column($goodsList, 'goods_id');
  75. $category_ids = array_column($goodsList, 'category_id');
  76. $brand_ids = array_column($goodsList, 'brand_id');
  77. $this->success('获取成功', [
  78. 'coupons' => UserCoupon::myGoodsCoupon($userId, $goods_ids, $category_ids, $brand_ids),
  79. 'goods_list' => $goodsList,
  80. 'order_info' => $orderInfo,
  81. ]);
  82. }
  83. /**
  84. * 提交订单 - 统一接口
  85. */
  86. public function create()
  87. {
  88. // 验证请求参数
  89. $validate = new \app\api\validate\Order();
  90. if (!$validate->scene('create')->check($this->request->post())) {
  91. $this->error($validate->getError());
  92. }
  93. $address_id = $this->request->post('address_id/d'); // 地址id
  94. $user_coupon_id = $this->request->post('user_coupon_id/d'); // 优惠券id
  95. $remark = $this->request->post('remark','','trim'); // 备注
  96. $cart_ids = $this->request->post('cart_ids/a'); // 购物车ID数组
  97. $goods_list = $this->request->post('goods_list/a'); // 商品列表
  98. $userId = $this->auth->id;
  99. $order = null;
  100. try {
  101. if (!empty($cart_ids)) {
  102. // 购物车模式 - 校验购物车id合法性
  103. $row = (new Carts)->where('id', 'IN', $cart_ids)->where('user_id', '<>', $this->auth->id)->find();
  104. if ($row) {
  105. $this->error('存在不合法购物车数据');
  106. }
  107. // 先转换购物车为商品列表
  108. $goods_list = CartService::convertCartToGoodsList($cart_ids, $userId);
  109. // 创建订单
  110. $order = OrderService::createOrder($address_id, $userId, $goods_list, $user_coupon_id, $remark);
  111. // 购物车订单创建成功后清理购物车
  112. CartService::clear($cart_ids,$userId);
  113. } elseif (!empty($goods_list)) {
  114. // 商品列表模式 - 直接创建订单
  115. $order = OrderService::createOrder($address_id, $userId, $goods_list, $user_coupon_id, $remark);
  116. } else {
  117. $this->error('请提供购物车ID或商品列表');
  118. }
  119. } catch (\Exception $e) {
  120. $this->error($e->getMessage());
  121. }
  122. $this->success('下单成功!', array_intersect_key($order->toArray(), array_flip(['order_sn', 'id', 'order_status'])));
  123. }
  124. /**
  125. * 创建单商品订单 - 一个商品一个订单
  126. */
  127. public function createSingleGoods()
  128. {
  129. // 验证请求参数
  130. $validate = new \app\api\validate\Order();
  131. if (!$validate->scene('create')->check($this->request->post())) {
  132. $this->error($validate->getError());
  133. }
  134. $address_id = $this->request->post('address_id/d'); // 地址id
  135. $user_coupon_id = $this->request->post('user_coupon_id/d'); // 优惠券id(仅用于第一个订单)
  136. $remark = $this->request->post('remark','','trim'); // 备注
  137. $cart_ids = $this->request->post('cart_ids/a'); // 购物车ID数组
  138. $goods_list = $this->request->post('goods_list/a'); // 商品列表
  139. $userId = $this->auth->id;
  140. $orders = [];
  141. try {
  142. if (!empty($cart_ids)) {
  143. // 购物车模式 - 校验购物车id合法性
  144. $row = (new Carts)->where('id', 'IN', $cart_ids)->where('user_id', '<>', $this->auth->id)->find();
  145. if ($row) {
  146. $this->error('存在不合法购物车数据');
  147. }
  148. // 先转换购物车为商品列表
  149. $goods_list = CartService::convertCartToGoodsList($cart_ids, $userId);
  150. // 创建单商品订单
  151. $orders = OrderService::createSingleGoodsOrders($address_id, $userId, $goods_list, $user_coupon_id, $remark);
  152. // 购物车订单创建成功后清理购物车
  153. CartService::clear($cart_ids, $userId);
  154. } elseif (!empty($goods_list)) {
  155. // 商品列表模式 - 直接创建单商品订单
  156. $orders = OrderService::createSingleGoodsOrders($address_id, $userId, $goods_list, $user_coupon_id, $remark);
  157. } else {
  158. $this->error('请提供购物车ID或商品列表');
  159. }
  160. } catch (\Exception $e) {
  161. $this->error($e->getMessage());
  162. }
  163. // 格式化返回数据
  164. $orderResults = [];
  165. foreach ($orders as $order) {
  166. $orderResults[] = array_intersect_key($order->toArray(), array_flip(['order_sn', 'id', 'order_status']));
  167. }
  168. $this->success('下单成功!共创建 ' . count($orders) . ' 个订单', [
  169. 'order_count' => count($orders),
  170. 'orders' => $orderResults
  171. ]);
  172. }
  173. /**
  174. * 创建父子订单 - 每个商品一个子订单,统一支付父订单
  175. */
  176. public function createParentChild()
  177. {
  178. // 验证请求参数
  179. $validate = new \app\api\validate\Order();
  180. if (!$validate->scene('create')->check($this->request->post())) {
  181. $this->error($validate->getError());
  182. }
  183. $address_id = $this->request->post('address_id/d'); // 地址id
  184. $user_coupon_id = $this->request->post('user_coupon_id/d'); // 优惠券id
  185. $remark = $this->request->post('remark','','trim'); // 备注
  186. $cart_ids = $this->request->post('cart_ids/a'); // 购物车ID数组
  187. $goods_list = $this->request->post('goods_list/a'); // 商品列表
  188. $userId = $this->auth->id;
  189. $parentOrder = null;
  190. try {
  191. if (!empty($cart_ids)) {
  192. // 购物车模式 - 校验购物车id合法性
  193. $row = (new Carts)->where('id', 'IN', $cart_ids)->where('user_id', '<>', $this->auth->id)->find();
  194. if ($row) {
  195. $this->error('存在不合法购物车数据');
  196. }
  197. // 先转换购物车为商品列表
  198. $goods_list = CartService::convertCartToGoodsList($cart_ids, $userId);
  199. // 创建父子订单
  200. $parentOrder = ParentOrderService::createParentChildOrders($address_id, $userId, $goods_list, $user_coupon_id, $remark);
  201. // 购物车订单创建成功后清理购物车
  202. CartService::clear($cart_ids, $userId);
  203. } elseif (!empty($goods_list)) {
  204. // 商品列表模式 - 直接创建父子订单
  205. $parentOrder = ParentOrderService::createParentChildOrders($address_id, $userId, $goods_list, $user_coupon_id, $remark);
  206. } else {
  207. $this->error('请提供购物车ID或商品列表');
  208. }
  209. } catch (\Exception $e) {
  210. $this->error($e->getMessage());
  211. }
  212. // 获取子订单信息
  213. $childOrders = [];
  214. foreach ($parentOrder->childOrders as $childOrder) {
  215. $childOrders[] = [
  216. 'order_sn' => $childOrder->order_sn,
  217. 'id' => $childOrder->id,
  218. 'order_status' => $childOrder->order_status,
  219. 'amount' => $childOrder->amount,
  220. 'goods_price' => $childOrder->goods_price,
  221. 'express_fee' => $childOrder->express_fee
  222. ];
  223. }
  224. $this->success('父子订单创建成功!', [
  225. 'parent_order' => [
  226. 'parent_order_sn' => $parentOrder->parent_order_sn,
  227. 'id' => $parentOrder->id,
  228. 'order_status' => $parentOrder->order_status,
  229. 'pay_status' => $parentOrder->pay_status,
  230. 'total_amount' => $parentOrder->total_amount,
  231. 'pay_amount' => $parentOrder->pay_amount,
  232. 'child_order_count' => count($childOrders)
  233. ],
  234. 'child_orders' => $childOrders
  235. ]);
  236. }
  237. //订单详情
  238. public function detail()
  239. {
  240. // 验证请求参数
  241. $validate = new \app\api\validate\Order();
  242. $orderId = $this->request->get('orderId');
  243. $params = ['orderId' => $orderId];
  244. if (!$validate->scene('detail')->check($params)) {
  245. $this->error($validate->getError());
  246. }
  247. $order = OrderService::getDetail($orderId, $this->auth->id);
  248. if (empty($order)) {
  249. $this->error('未找到订单');
  250. }
  251. //$order->append(['order_status_text']);
  252. $address = OrderService::getAddressInfo($orderId);
  253. $order->address = $address;
  254. // $order->append(['status_text']);
  255. // $order->hidden(explode(',', 'method,transactionid,updatetime,deletetime'));
  256. // $order->expiretime = $order->expiretime - time();
  257. $order->order_status_text = OrderEnum::STATUS_TEXT_MAP[$order->order_status];
  258. // 处理商品的 发货信息
  259. foreach ($order->order_goods as $item) {
  260. $item->express_image = json_decode($item->express_image, true);
  261. }
  262. $this->success('', $order);
  263. }
  264. //订单列表
  265. public function index()
  266. {
  267. // 验证请求参数
  268. $validate = new \app\api\validate\Order();
  269. $param = $this->request->param();
  270. $param['time_range'] = '1'; // 添加触发时间范围验证的字段
  271. if (!$validate->scene('lists')->check($param)) {
  272. $this->error($validate->getError());
  273. }
  274. // 设置默认值
  275. $userId = $this->auth->id;
  276. $param['page'] = $this->request->param('page', 1, 'intval');
  277. $param['pageSize'] = $this->request->param('pageSize', 10, 'intval');
  278. $status = $this->request->param('status', 0, 'intval'); // 默认为0(全部订单)
  279. $param['keywords'] = $this->request->param('keywords', '', 'trim');
  280. $status = OrderEnum::SHOW_TYPE_STATUS_MAP[$status];
  281. $list = OrderService::getOrderList($userId ,$param, $status);
  282. foreach ($list as $item) {
  283. // $item->append(['order_status_text']);
  284. $field = 'id,order_sn,amount,goods_price,order_amount,express_name,express_no,order_goods,order_status_text,order_status';
  285. $item->visible(explode(',', $field));
  286. $item->order_status_text = OrderEnum::STATUS_TEXT_MAP[$item->order_status];
  287. }
  288. $this->success('获取成功', $list);
  289. }
  290. //取消订单
  291. public function cancel()
  292. {
  293. // 验证请求参数
  294. $validate = new \app\api\validate\Order();
  295. $orderId = $this->request->post('orderId');
  296. $params = ['orderId' => $orderId];
  297. if (!$validate->scene('cancel')->check($params)) {
  298. $this->error($validate->getError());
  299. }
  300. $order = OrderService::getByOrderId($orderId);
  301. if (empty($order)) {
  302. $this->error('订单不存在');
  303. }
  304. if ($order->user_id != $this->auth->id) {
  305. $this->error('不能越权操作');
  306. }
  307. if ($order->status == 'hidden') {
  308. $this->error('订单已失效!');
  309. }
  310. //可以取消
  311. if ($order->canCancelHandle()) {
  312. // 启动事务
  313. Db::startTrans();
  314. try {
  315. $order->order_status = OrderEnum::STATUS_CANCEL;
  316. $order->cancel_time = time();
  317. $order->save();
  318. foreach ($order->order_goods as $item) {
  319. $sku = $item->sku;
  320. $goods = $item->goods;
  321. //商品库存恢复
  322. if ($sku) {
  323. $sku->setInc('stocks', $item->nums);
  324. }
  325. if ($goods) {
  326. $goods->setInc('stocks', $item->nums);
  327. }
  328. }
  329. //恢复优惠券
  330. UserCoupon::resetUserCoupon($order->user_coupon_id, $order->order_sn);
  331. // 提交事务
  332. Db::commit();
  333. } catch (\Exception $e) {
  334. // 回滚事务
  335. Db::rollback();
  336. $this->error('订单取消失败');
  337. }
  338. //记录操作
  339. OrderAction::push($order->order_sn, '系统', '订单取消成功');
  340. $this->success('订单取消成功!', $order['status']);
  341. } else {
  342. $this->error('订单不允许取消');
  343. }
  344. }
  345. //确认收货
  346. public function receipt()
  347. {
  348. // 验证请求参数
  349. $validate = new \app\api\validate\Order();
  350. $orderId = $this->request->post('orderId');
  351. $params = ['orderId' => $orderId];
  352. if (!$validate->scene('detail')->check($params)) {
  353. $this->error($validate->getError());
  354. }
  355. $order = OrderService::getByOrderId($orderId);
  356. if (empty($order)) {
  357. $this->error('订单不存在');
  358. }
  359. if ($order->user_id != $this->auth->id) {
  360. $this->error('该订单不属于当前用户');
  361. }
  362. if ($order->canConfirmHandle()) {
  363. $order->order_status = OrderEnum::STATUS_CONFIRM;
  364. $order->receive_time = time();
  365. $order->save();
  366. //记录操作
  367. OrderAction::push($order->order_sn, '系统', '订单确认收货成功');
  368. $this->success('确认收货成功');
  369. }
  370. $this->error('订单不允许确认收货');
  371. }
  372. //查询物流
  373. public function logistics()
  374. {
  375. // 验证请求参数
  376. $validate = new \app\api\validate\Order();
  377. $params = ['order_sn' => $this->request->param('order_sn')];
  378. if (!$validate->scene('detail')->check($params)) {
  379. $this->error($validate->getError());
  380. }
  381. $order_sn = $this->request->param('order_sn');
  382. $order = OrderModel::getDetail($order_sn, $this->auth->id);
  383. if (empty($order)) {
  384. $this->error('未找到订单');
  385. }
  386. if (!$order->shippingstate) {
  387. $this->error('订单未发货');
  388. }
  389. $electronics = Db::name('shop_order_electronics')->where('order_sn', $order_sn)->where('status', 0)->find();
  390. if (!$electronics) {
  391. $this->error('订单未发货');
  392. }
  393. $result = KdApiExpOrder::getLogisticsQuery([
  394. 'order_sn' => $order_sn,
  395. 'logistic_code' => $electronics['logistic_code'],
  396. 'shipper_code' => $electronics['shipper_code']
  397. ]);
  398. if ($result['Success']) {
  399. $this->success('查询成功', $result['Traces']);
  400. }
  401. $this->error('查询失败');
  402. }
  403. // 获取状态订单统计
  404. public function getOrderStatusCount(){
  405. $userId = $this->auth->id;
  406. $info = OrderService::getOrderStatusCount($userId);
  407. $this->success('获取成功', $info);
  408. }
  409. }