ShopOrderLogic.php 6.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171
  1. <?php
  2. namespace app\workerapi\logic\shops;
  3. use app\common\logic\BaseLogic;
  4. use app\common\model\article\Article;
  5. use app\common\model\decorate\DecoratePage;
  6. use app\common\model\decorate\DecorateTabbar;
  7. use app\common\model\setting\PostageRegion;
  8. use app\common\model\shops\ShopAddress;
  9. use app\common\model\shops\ShopCart;
  10. use app\common\model\shops\ShopGoods;
  11. use app\common\model\shops\ShopGoodSpecsInventory;
  12. use app\common\model\shops\ShopOrderGoods;
  13. use app\common\model\shops\ShopOrders;
  14. use app\common\model\user\UserAddress;
  15. use app\common\service\ConfigService;
  16. use app\common\service\FileService;
  17. use think\db\Query;
  18. use think\Exception;
  19. use think\facade\Db;
  20. /**
  21. * 订单
  22. */
  23. class ShopOrderLogic extends BaseLogic
  24. {
  25. /**
  26. * 提交订单
  27. * @param array $params
  28. * @return array|false
  29. */
  30. public static function submitOrder($params)
  31. {
  32. Db::startTrans();
  33. try {
  34. //获取购物车商品
  35. $shop_carts = ShopCart::whereIn('id',$params['shop_cart_id'])->where('worker_id',$params['user_id'])->select()->toArray();
  36. if(empty($shop_carts)){
  37. throw new Exception('购物车商品不存在');
  38. }
  39. //生成订单编号
  40. $sn = generate_sn(ShopOrders::class, 'sn');
  41. $shop_order_goods = array();
  42. $amount_total = 0;//总价
  43. $amount = 0;//应支付价格
  44. //验证商品库存是否存在
  45. foreach ($shop_carts as $v){
  46. $inventory = ShopGoodSpecsInventory::where('id',$v['goods_specs_inventory_id'])->findOrEmpty();
  47. $shop_good = ShopGoods::where('id',$v['shop_goods_id'])->findOrEmpty()->toArray();
  48. if($inventory->remaining_inventory<$v['number']){
  49. throw new Exception($shop_good['goods_name'].'库存不足');
  50. }
  51. //新增订单商品镜像
  52. $shop_order_goods[] = [
  53. 'sn'=>$sn,
  54. 'shop_goods_id'=>$shop_good['id'],
  55. 'goods_category_ids' => $shop_good['goods_category_ids'],
  56. 'goods_category_id' => $shop_good['goods_category_id'],
  57. 'goods_name' => $shop_good['goods_name'],
  58. 'goods_image' => $shop_good['goods_image'],
  59. 'goods_banners' => $shop_good['goods_banners'],
  60. 'description' => $shop_good['description'],
  61. 'specs_type' => $shop_good['specs_type'],
  62. 'custom_attribute_items'=>json_encode($shop_good['custom_attribute_items'],JSON_UNESCAPED_UNICODE),
  63. 'goods_specs_inventory_id'=>$v['goods_specs_inventory_id'],
  64. 'specs'=>json_encode($inventory->specs,JSON_UNESCAPED_UNICODE),
  65. 'number'=>$v['number'],
  66. 'service_total'=>$inventory->service_total,
  67. 'service_fee'=>$inventory->service_fee
  68. ];
  69. //减少商品库存
  70. $inventory->remaining_inventory = $inventory->remaining_inventory-1;
  71. $inventory->save();
  72. $amount_total += $inventory['service_total'];
  73. $amount += $inventory['service_fee'];
  74. }
  75. //生成订单
  76. $order = ShopOrders::create([
  77. 'shop_order_type' => 1,
  78. 'worker_id' => $params['user_id'],
  79. 'sn' => $sn,
  80. 'real_name' => $params['real_name'],
  81. 'mobile' => $params['mobile'],
  82. 'address' => $params['address'],
  83. 'pay_status' => 0,
  84. 'paw_way' => 2,
  85. 'order_terminal' => $params['terminal'],
  86. 'amount_total' => $amount_total,
  87. 'amount' => $amount,
  88. ]);
  89. //生成订单商品镜像
  90. $ShopOrderGoods = new ShopOrderGoods();
  91. $ShopOrderGoods->saveAll($shop_order_goods);
  92. //清除购物车商品
  93. ShopCart::whereIn('id',$params['shop_cart_id'])->delete();
  94. Db::commit();
  95. } catch (\Exception $e) {
  96. self::setError($e->getMessage());
  97. return false;
  98. }
  99. return [
  100. 'order_id' => (int)$order['id'],
  101. ];
  102. }
  103. /**
  104. * @notes 获取详情
  105. * @param $params
  106. * @return array
  107. * @author likeadmin
  108. * @date 2024/07/18 13:51
  109. */
  110. public static function detail($params): array
  111. {
  112. $detail = ShopOrders::with(['orderGoods'=>function(Query $query){
  113. $query->field(['sn','goods_name','goods_image','number','service_fee','company_name','delivery_type','shop_goods_type','goods_specs_inventory_id','specs_type','custom_attribute_items','specs'])->append(['spec_arr','delivery_type_text','shop_goods_type_text']);
  114. }])->field('id, sn, real_name,mobile, address,pay_time, paw_way,pay_sn, pay_status, refund_status, refund_transaction_id,create_time,shop_order_type,amount_total, amount')
  115. ->append(['pay_way_text','pay_status_text','refund_status_text'])->where(['sn'=> $params['sn'],'worker_id'=>$params['worker_id']])->findOrEmpty()->toArray();
  116. $orderGoodsArr = [];
  117. $companyNameArr = array_column($detail['orderGoods'],'company_name');
  118. foreach($companyNameArr as $val) {
  119. $orderGoods = [];
  120. foreach ($detail['orderGoods'] as $goodVal) {
  121. if($val == $goodVal['company_name']){
  122. unset($goodVal['goodsSpecsInventory'], $goodVal['custom_attribute_items'], $goodVal['specs'], $goodVal['sn'], $goodVal['goods_specs_inventory_id'],$goodVal['company_name']);
  123. $orderGoods[] = $goodVal;
  124. }
  125. }
  126. if(!empty($orderGoods)){
  127. $orderGoodsArr[] = [
  128. 'company_name' => $val,
  129. 'goods' => $orderGoods
  130. ];
  131. }
  132. }
  133. $detail['orderGoods'] = $orderGoodsArr;
  134. return $detail;
  135. }
  136. public static function cancelOrder($params):bool
  137. {
  138. Db::startTrans();
  139. try {
  140. $orderModel = ShopOrders::where([
  141. 'shop_order_type' => 1,
  142. 'worker_id' => $params['worker_id'],
  143. 'sn'=>$params['sn']
  144. ])->findOrEmpty();
  145. if($orderModel->isEmpty()){
  146. throw new \Exception('订单不存在或不是待支付状态');
  147. }
  148. $orderModel->shop_order_type = 0;
  149. $orderModel->save();
  150. Db::commit();
  151. return true;
  152. } catch (\Exception $e) {
  153. Db::rollback();
  154. self::setError($e->getMessage());
  155. return false;
  156. }
  157. }
  158. }