sku完成，订单、商品上下架管理正在搞

2025-05-21 17:04:10 +08:00
parent 035ab1105c
commit fc503cb95a
18 changed files with 239579 additions and 22 deletions
--- a/app/Service/CodeGeneration/OrderService.php
+++ b/app/Service/CodeGeneration/OrderService.php
@@ -3,8 +3,15 @@
 namespace App\Service\CodeGeneration;

 use App\BaseApp\BaseService;
+use App\Enum\order\OrderStatusEnum;
+use App\Models\OrderDetailModel;
 use App\Models\OrderModel;
+use App\Models\ProductModel;
+use App\Models\SkuModel;
+use App\Models\UserModel;
+use App\Models\UserReceivingAddressModel;
 use Exception;
+use Illuminate\Support\Facades\DB;
 use Psr\Container\ContainerExceptionInterface;
 use Psr\Container\NotFoundExceptionInterface;

@@ -16,6 +23,9 @@ class OrderService extends BaseService
        $this->selectField = ["id", "user_id", "order_no", "order_status", "total_amount", "status", "created_at", "updated_at", "deleted_at"];
        $this->queryField = ['user_id' => '=','order_no' => 'like','order_status' => '=,status='];
        $this->model = OrderModel::class;
+        $this->with = [
+            'user:id,nick_name,avatar'
+        ];
    }

    /**
@@ -26,7 +36,12 @@ class OrderService extends BaseService
     */
    public function list(): array
    {
-        return $this->getPageList();
+        $result = $this->getPageList();
+        foreach ($result['items'] as &$v) {
+            $v['status_text'] = OrderStatusEnum::from($v['status'])->description();
+            $v['status_color'] = OrderStatusEnum::from($v['status'])->getColor();
+        }
+        return $result;
    }

    /**
@@ -37,7 +52,16 @@ class OrderService extends BaseService
     */
    public function detail($id)
    {
-        return $this->getDetail($id);
+        $this->selectField[] = 'recipient';
+        $this->with[] = 'detail:id,order_id,product_id,sku_id,price,quantity,subtotal,snapshot';
+        $result = $this->getDetail($id);
+        $result['status_text'] = OrderStatusEnum::from($result['status'])->description();
+        $result['status_color'] = OrderStatusEnum::from($result['status'])->getColor();
+        $result['recipient'] = json_decode($result['recipient'], true);
+        foreach ($result['detail'] as &$v) {
+            $v['snapshot'] = !empty($v['snapshot'])  ? json_decode($v['snapshot'], true) : [];
+        }
+        return $result;
    }

    /**
@@ -84,4 +108,97 @@ class OrderService extends BaseService
        return $this->del($ids);
    }

+    public function generateOrder($params)
+    {
+        $userIds = UserModel::pluck('id');
+        $userId = $userIds->random();
+
+        $skuIds = array_column($params['products'], 'sku_id');
+        $skuQuantity = array_column($params['products'], 'number', 'sku_id');
+
+        $skus = SkuModel::with('product')->whereIn('id', $skuIds)->get();
+        if (empty($skus)) {
+            $this->utils->errorThrow('商品sku不存在！');
+        }
+
+        $skus = $skus->toArray();
+
+        $skuGetIds = array_column($skus, 'id');
+        // 对比skuIds和skuGetIds如果传入的skuId不存在于skuGetIds中，则抛出异常
+        $diffSkuIds = array_diff($skuIds, $skuGetIds);
+        if ($diffSkuIds) {
+            $this->utils->errorThrow('商品sku不存在！SkuId：'. implode(',', $diffSkuIds));
+        }
+
+        // 获取收件人地址
+        $recipient = $this->getRecipientInfo($params['address_id']?? 0);
+
+        // 生成订单号
+        $orderNo = $this->utils->genOrderNo();
+
+        $orderInsertData = [
+            'user_id' => $userId,
+            'order_no' => $orderNo,
+            'total_amount' => 0,
+            'recipient' => $recipient,
+            'user_remarks' => $params['user_remarks'] ?? '',
+            'status' => 0,
+        ];
+
+        DB::beginTransaction();
+        try {
+            $totalAmount = 0;
+            $orderId = $this->insert($orderInsertData);
+
+            if (!$orderId) {
+                $this->utils->errorThrow('订单生成失败！');
+            }
+
+            $orderProducts = [];
+            foreach ($skus as $v) {
+                $subtotal = bcmul($v['price'], $skuQuantity[$v['id']], 2);
+                $orderProducts[] = [
+                    'order_id' => $orderId,
+                    'product_id' => $v['product_id'],
+                    'sku_id' => $v['id'],
+                    'price' => $v['price'],
+                    'quantity' => $skuQuantity[$v['id']],
+                    'subtotal' => $subtotal,
+                    'snapshot' => json_encode($v),
+                ];
+                $totalAmount = bcadd($totalAmount, $subtotal, 2);
+            }
+
+            $orderDetailInsertModel = OrderDetailModel::insert($orderProducts);
+
+            if (!$orderDetailInsertModel) {
+                $this->utils->errorThrow('订单商品生成失败！');
+            }
+
+            $orderUpdateModel = $this->update($orderId, [
+                'total_amount' => $totalAmount,
+            ]);
+
+            if (!$orderUpdateModel) {
+                $this->utils->errorThrow('订单生成失败！');
+            }
+            DB::commit();
+        } catch (Exception $e) {
+            DB::rollBack();
+            $this->utils->errorThrow($e->getMessage());
+        }
+
+        return $orderId;
+    }
+
+    public function getRecipientInfo($id = null)
+    {
+        if (empty($id)) {
+            $this->utils->errorThrow('请选择收件人！');
+        }
+
+        $recipientInfo = UserReceivingAddressModel::where('id', $id)->first();
+        $recipientInfo['copy_text'] = "{$recipientInfo['name']} {$recipientInfo['phone']} {$recipientInfo['complete_address']}";
+        return json_encode($recipientInfo);
+    }
 }
--- a/app/Service/CodeGeneration/ProductService.php
+++ b/app/Service/CodeGeneration/ProductService.php
@@ -37,6 +37,14 @@ class ProductService extends BaseService
     */
    public function list(): array
    {
+        $this->with = [
+            'images:id,product_id,url',
+            'mall:id,name,avatar',
+            'user:id,nick_name,avatar',
+            'labels',
+            'classification',
+            'skus:id,product_id,name,cover,price,inventory',
+        ];
        $result = $this->getPageList();
        foreach ($result['items'] as &$v) {
            $v['images'] = array_column($v['images'], 'url');
--- a/app/Service/CodeGeneration/RegionService.php
+++ b/app/Service/CodeGeneration/RegionService.php
@@ -0,0 +1,87 @@
+<?php
+
+namespace App\Service\CodeGeneration;
+
+use App\BaseApp\BaseService;
+use App\Models\RegionModel;
+use Exception;
+use Psr\Container\ContainerExceptionInterface;
+use Psr\Container\NotFoundExceptionInterface;
+
+class RegionService extends BaseService
+{
+    public function __construct()
+    {
+        parent::__construct();
+        $this->selectField = ["id", "name", "pid", "status", "price", "created_at", "updated_at", "deleted_at"];
+        $this->queryField = ['name' => '=','pid' => '=,status='];
+        $this->model = RegionModel::class;
+    }
+
+    /**
+     * 获取地区列表
+     * @return array
+     * @throws ContainerExceptionInterface
+     * @throws NotFoundExceptionInterface
+     */
+    public function list(): array
+    {
+        return $this->getPageList();
+    }
+
+    /**
+     * 获取地区详情
+     * @param $id
+     * @return mixed
+     * @throws Exception
+     */
+    public function detail($id)
+    {
+        return $this->getDetail($id);
+    }
+
+    /**
+     * 地区下拉列表
+     * @return mixed
+     */
+    public function option()
+    {
+        $this->optionField = ['id', 'name'];
+        return $this->getOption();
+    }
+
+    /**
+     * 创建地区
+     * @param $params
+     * @return mixed
+     * @throws Exception
+     */
+    public function create($params): mixed
+    {
+        return $this->insert($params);
+    }
+
+    /**
+     * 编辑地区
+     * @param $id
+     * @param $params
+     * @return mixed
+     * @throws Exception
+     */
+    public function update($id, $params): mixed
+    {
+        return $this->save($id, $params);
+    }
+
+    /**
+     * 删除地区
+     * @param $ids
+     * @return mixed|true
+     * @throws Exception
+     */
+    public function delete($ids): mixed
+    {
+        return $this->del($ids);
+    }
+
+}
--- a/app/Service/CodeGeneration/SkuService.php
+++ b/app/Service/CodeGeneration/SkuService.php
@@ -21,6 +21,11 @@ class SkuService extends BaseService
        ];
    }

+    public function getSkuByProductId($id)
+    {
+        return $this->model::where('product_id', $id)->orderBy('id', 'desc')->get();
+    }
+
    /**
     * 获取sku管理列表
     * @return array
--- a/app/Service/CodeGeneration/UserReceivingAddressService.php
+++ b/app/Service/CodeGeneration/UserReceivingAddressService.php
@@ -3,6 +3,7 @@
 namespace App\Service\CodeGeneration;

 use App\BaseApp\BaseService;
+use App\Models\RegionModel;
 use App\Models\UserReceivingAddressModel;
 use Exception;
 use Psr\Container\ContainerExceptionInterface;
@@ -13,9 +14,15 @@ class UserReceivingAddressService extends BaseService
    public function __construct()
    {
        parent::__construct();
-        $this->selectField = ["id", "user_id", "province", "city", "district", "detailed_address", "complete_address", "status", "created_at", "updated_at", "deleted_at"];
+        $this->selectField = ["id", "user_id", "province", "total_address", "city", "district", "name", "phone", "is_default", "detailed_address", "complete_address", "status", "created_at", "updated_at", "deleted_at"];
        $this->queryField = ['user_id' => '=','province' => '=','city' => '=','district' => '=','detailed_address' => '=','complete_address' => '=,status='];
        $this->model = UserReceivingAddressModel::class;
+        $this->with = [
+            'user:id,nick_name',
+            'provinceInfo:id,name',
+            'cityInfo:id,name',
+            'districtInfo:id,name',
+        ];
    }

    /**
@@ -26,7 +33,11 @@ class UserReceivingAddressService extends BaseService
     */
    public function list(): array
    {
-        return $this->getPageList();
+        $result = $this->getPageList();
+        foreach ($result['items'] as &$v) {
+            $v['total_address'] = json_decode($v['total_address']);
+        }
+        return $result;
    }

    /**
@@ -58,6 +69,7 @@ class UserReceivingAddressService extends BaseService
     */
    public function create($params): mixed
    {
+        $params = $this->checkAddress($params);
        return $this->insert($params);
    }

@@ -70,6 +82,7 @@ class UserReceivingAddressService extends BaseService
     */
    public function update($id, $params): mixed
    {
+        $params = $this->checkAddress($params);
        return $this->save($id, $params);
    }

@@ -84,4 +97,15 @@ class UserReceivingAddressService extends BaseService
        return $this->del($ids);
    }

+    public function checkAddress($params)
+    {
+        $data = RegionModel::whereIn('id', $params['total_address'])->get(['id', 'name']);
+        $regionName = array_column($data->toArray(), 'name');
+        $params['complete_address'] = implode('', $regionName). ' '. $params['detailed_address'];
+        $params['province'] = $params['total_address'][0];
+        $params['city'] = $params['total_address'][1];
+        $params['district'] = $params['total_address'][2];
+        $params['total_address'] = json_encode($params['total_address']);
+        return $params;
+    }
 }
--- a/app/Service/common/UtilsService.php
+++ b/app/Service/common/UtilsService.php
@@ -185,15 +185,53 @@ class UtilsService
     */
    public function genOrderNo(int $type = 0): string
    {
-        $len = 9999999999;
-        switch ($type) {
-            case 0:
-                return 'DK' . date('Ymd') . str_pad(mt_rand(1, $len), 11, '0', STR_PAD_LEFT);
-            case 1:
-                return 'DD' . date('Ymd') . str_pad(mt_rand(1, $len), 11, '0', STR_PAD_LEFT);
-            default:
-                return '';
+
+        $prefix = ['NL', 'TX', 'TK'];
+        $datePart = date('Ymd');
+
+        // 确保len不超过PHP_INT_MAX，避免整数溢出
+        $maxLen = PHP_INT_MAX;
+
+        // 使用bcmath扩展生成安全的大数随机数
+        if (function_exists('bcadd') && function_exists('bcmul')) {
+            // 生成一个10位的随机字符串作为基础
+            $randomBase = '';
+            for ($i = 0; $i < 10; $i++) {
+                $randomBase .= mt_rand(0, 9);
+            }
+
+            // 使用bcmath计算一个大数随机数
+            $randomPart = bcadd(
+                '1', // 确保最小值为1
+                bcmul(
+                    $randomBase,
+                    bcdiv((string)$maxLen, '10000000000', 0),
+                    0
+                )
+            );
+
+            // 截取前11位数字
+            $randomStr = substr($randomPart, 0, 11);
+        } else {
+            // 备用方案：使用mt_rand并处理溢出
+            $randomNum = mt_rand(1, $maxLen);
+            $randomStr = (string)$randomNum;
+
+            // 如果长度不足11位，左侧补0
+            if (strlen($randomStr) < 11) {
+                $randomStr = str_pad($randomStr, 11, '0', STR_PAD_LEFT);
+            } else {
+                // 如果长度超过11位，截取前11位
+                $randomStr = substr($randomStr, 0, 11);
+            }
        }
+
+        // 确保随机部分长度为11
+        $paddedRandom = str_pad($randomStr, 11, '0', STR_PAD_LEFT);
+        $paddedRandom = substr($paddedRandom, -11); // 确保最终长度为11
+
+        // 返回格式化后的代码
+        return isset($prefix[$type]) ? $prefix[$type] . $datePart . $paddedRandom : '';
    }

    /**