ShopOrderLogic.php 7.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175
  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. $addressInfo = ShopAddress::field('area,address,house_number,contact_number,contact_people')->findOrEmpty($params['address_id']);
  40. if($addressInfo->isEmpty()){
  41. throw new \Exception('收货地址不存在');
  42. }
  43. //生成订单编号
  44. $sn = generate_sn(ShopOrders::class, 'sn');
  45. $shop_order_goods = array();
  46. $amount_total = 0;//总价
  47. $amount = 0;//应支付价格
  48. //验证商品库存是否存在
  49. foreach ($shop_carts as $v){
  50. $inventory = ShopGoodSpecsInventory::where('id',$v['goods_specs_inventory_id'])->findOrEmpty();
  51. $shop_good = ShopGoods::where('id',$v['shop_goods_id'])->findOrEmpty()->toArray();
  52. if($inventory->remaining_inventory<$v['number']){
  53. throw new Exception($shop_good['goods_name'].'库存不足');
  54. }
  55. //新增订单商品镜像
  56. $shop_order_goods[] = [
  57. 'sn'=>$sn,
  58. 'shop_goods_id'=>$shop_good['id'],
  59. 'goods_category_ids' => $shop_good['goods_category_ids'],
  60. 'goods_category_id' => $shop_good['goods_category_id'],
  61. 'goods_name' => $shop_good['goods_name'],
  62. 'goods_image' => $shop_good['goods_image'],
  63. 'goods_banners' => $shop_good['goods_banners'],
  64. 'company_name' => $shop_good['company_name'],
  65. 'description' => $shop_good['description'],
  66. 'specs_type' => $shop_good['specs_type'],
  67. 'custom_attribute_items'=>json_encode($shop_good['custom_attribute_items'],JSON_UNESCAPED_UNICODE),
  68. 'goods_specs_inventory_id'=>$v['goods_specs_inventory_id'],
  69. 'specs'=>json_encode($inventory->specs,JSON_UNESCAPED_UNICODE),
  70. 'number'=>$v['number'],
  71. 'service_total'=>$inventory->service_total,
  72. 'service_fee'=>$inventory->service_fee
  73. ];
  74. //减少商品库存
  75. $inventory->remaining_inventory = $inventory->remaining_inventory-$v['number'];
  76. $inventory->save();
  77. $amount_total += $inventory['service_total'];
  78. $amount += $inventory['service_fee'];
  79. }
  80. //生成订单
  81. $order = ShopOrders::create([
  82. 'shop_order_type' => 1,
  83. 'worker_id' => $params['user_id'],
  84. 'sn' => $sn,
  85. 'real_name' => $addressInfo->contact_people,
  86. 'mobile' => $addressInfo->contact_number,
  87. 'address' => trim($addressInfo->area .$addressInfo->address . $addressInfo->house_number),
  88. 'pay_status' => 0,
  89. 'paw_way' => 2,
  90. 'order_terminal' => $params['terminal'],
  91. 'amount_total' => $amount_total,
  92. 'order_amount' => $amount,
  93. 'address_json' => $addressInfo->toArray()
  94. ]);
  95. //生成订单商品镜像
  96. $ShopOrderGoods = new ShopOrderGoods();
  97. $ShopOrderGoods->saveAll($shop_order_goods);
  98. //清除购物车商品
  99. ShopCart::whereIn('id',$params['shop_cart_id'])->delete();
  100. Db::commit();
  101. } catch (\Exception $e) {
  102. self::setError($e->getMessage());
  103. return false;
  104. }
  105. return [
  106. 'order_id' => (int)$order['id'],
  107. ];
  108. }
  109. /**
  110. * @notes 获取详情
  111. * @param $params
  112. * @return array
  113. * @author likeadmin
  114. * @date 2024/07/18 13:51
  115. */
  116. public static function detail($params): array
  117. {
  118. $detail = ShopOrders::with(['orderGoods'=>function(Query $query){
  119. $query->field(['sn','goods_name','goods_image','number','service_fee','service_total','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']);
  120. }])->field('id, sn, real_name,mobile, address,address_json,pay_time, paw_way,pay_sn, pay_status, refund_status, refund_transaction_id,create_time,shop_order_type,amount_total, order_amount')
  121. ->append(['pay_way_text','pay_status_text','refund_status_text'])->where(['sn'=> $params['sn'],'worker_id'=>$params['worker_id']])->findOrEmpty()->toArray();
  122. $orderGoodsArr = [];
  123. $companyNameArr = array_unique(array_column($detail['orderGoods'],'company_name'));
  124. foreach($companyNameArr as $val) {
  125. $orderGoods = [];
  126. foreach ($detail['orderGoods'] as $goodVal) {
  127. if($val == $goodVal['company_name']){
  128. unset($goodVal['goodsSpecsInventory'], $goodVal['custom_attribute_items'], $goodVal['specs'], $goodVal['sn'], $goodVal['goods_specs_inventory_id'],$goodVal['company_name']);
  129. $orderGoods[] = $goodVal;
  130. }
  131. }
  132. if(!empty($orderGoods)){
  133. $orderGoodsArr[] = [
  134. 'company_name' => $val,
  135. 'goods' => $orderGoods
  136. ];
  137. }
  138. }
  139. $detail['orderGoods'] = $orderGoodsArr;
  140. return $detail;
  141. }
  142. public static function cancelOrder($params):bool
  143. {
  144. Db::startTrans();
  145. try {
  146. $orderModel = ShopOrders::where([
  147. 'shop_order_type' => 1,
  148. 'worker_id' => $params['worker_id'],
  149. 'sn'=>$params['sn']
  150. ])->findOrEmpty();
  151. if($orderModel->isEmpty()){
  152. throw new \Exception('订单不存在或不是待支付状态');
  153. }
  154. $orderModel->shop_order_type = 0;
  155. $orderModel->save();
  156. Db::commit();
  157. return true;
  158. } catch (\Exception $e) {
  159. Db::rollback();
  160. self::setError($e->getMessage());
  161. return false;
  162. }
  163. }
  164. }