Merge pull request 'erp' (#83) from erp into dev

Reviewed-on: #83

app/admin/controller/WorkbenchController.php

@@ -14,6 +14,7 @@
 
 namespace app\admin\controller;
 
+use app\admin\lists\store_order_cart_info\StoreOrderCartInfoGroupLists;
 use app\admin\logic\statistic\ProductStatisticLogic;
 use app\admin\logic\statistic\TradeStatisticLogic;
 use app\admin\logic\statistic\UserStatisticLogic;
@@ -224,6 +225,14 @@ class WorkbenchController extends BaseAdminController
         return $this->data($data);
     }
 
+    /**
+     * 实时商品统计
+     */
+    public function product_order(){
+        return $this->dataLists(new StoreOrderCartInfoGroupLists());
+
+    }
+
         /**
      * 格式化时间
      * @param $time

app/admin/controller/purchase_order/PurchaseOrderController.php

@@ -0,0 +1,41 @@
+<?php 
+namespace app\admin\controller\purchase_order;
+use app\admin\controller\BaseAdminController;
+use app\admin\lists\purchase_order\PurchaseOrderLists;
+use app\admin\lists\purchase_order_info\PurchaseOrderInfoLists;
+use app\admin\logic\purchase_order\PurchaseOrderLogic;
+
+class PurchaseOrderController extends BaseAdminController{
+
+    public function lists()
+    {
+        return $this->dataLists(new PurchaseOrderLists());
+    }
+    public function info_lists()
+    {
+        return $this->dataLists(new PurchaseOrderInfoLists());
+    }
+    /**
+     * 合并今日商户订单
+     */
+    public function add(){
+        PurchaseOrderLogic::StoreTodayOrder();
+        return $this->success('合并成功');
+    }
+   /**
+     * 合并今日平台订单
+     */
+    public function platform(){
+        PurchaseOrderLogic::platformTodayOrder();
+        return $this->success('合并成功');
+    }
+
+      /**
+     * 详情
+     */
+    public function detail(){
+        $id=$this->request->get('id');
+        $res=PurchaseOrderLogic::detail($id);
+        return $this->data($res);
+    } 
+}

app/admin/controller/store_order_cart_info/StoreOrderCartInfoController.php

@@ -5,6 +5,7 @@ namespace app\admin\controller\store_order_cart_info;
 
 use app\admin\controller\BaseAdminController;
 use app\admin\lists\store_order_cart_info\StoreOrderCartInfoLists;
+use app\admin\lists\store_order_cart_info\StoreOrderCartInfoTwoLists;
 
 /**
  * 订单购物详情控制器
@@ -25,5 +26,8 @@ class StoreOrderCartInfoController extends BaseAdminController
     {
         return $this->dataLists(new StoreOrderCartInfoLists());
     }
-
+    public function listsTwo()
+    {
+        return $this->dataLists(new StoreOrderCartInfoTwoLists());
+    }
 }

app/admin/controller/store_product/StoreProductController.php

@@ -99,15 +99,16 @@ class StoreProductController extends BaseAdminController
         $product_arr = $this->request->post('product_arr');
         $store_arr = $this->request->post('store_arr');
         $stock_type = $this->request->post('stock_type',1);
+        $warehouse_id = $this->request->post('warehouse_id');
         if (count($store_arr) == 1) {
             $store_id = $store_arr[0];
             foreach ($product_arr as $key => $arr) {
-                Redis::send('store-storage', ['product_arr' => $arr, 'store_id' => $store_id,'stock_type'=>$stock_type, 'admin_id' => $this->adminId]);
+                Redis::send('store-storage', ['product_arr' => $arr, 'store_id' => $store_id,'stock_type'=>$stock_type, 'admin_id' => $this->adminId,'warehouse_id'=>$warehouse_id]);
             }
         } else {
             foreach ($product_arr as $key => $arr) {
                 foreach ($store_arr as $k => $store_id) {
-                    Redis::send('store-storage', ['product_arr' => $arr, 'store_id' => $store_id,'stock_type'=>$stock_type, 'admin_id' => $this->adminId]);
+                    Redis::send('store-storage', ['product_arr' => $arr, 'store_id' => $store_id,'stock_type'=>$stock_type, 'admin_id' => $this->adminId,'warehouse_id'=>$warehouse_id]);
                 }
             }
         }

app/admin/controller/warehouse/WarehouseController.php

@@ -0,0 +1,95 @@
+<?php
+
+namespace app\admin\controller\warehouse;
+
+
+use app\admin\controller\BaseAdminController;
+use app\admin\lists\warehouse\WarehouseLists;
+use app\admin\logic\warehouse\WarehouseLogic;
+use app\admin\validate\warehouse\WarehouseValidate;
+
+
+/**
+ * 仓库信息控制器
+ * Class WarehouseController
+ * @package app\admin\controller\warehouse
+ */
+class WarehouseController extends BaseAdminController
+{
+
+
+    /**
+     * @notes 获取仓库信息列表
+     * @return \think\response\Json
+     * @author admin
+     * @date 2024/07/31 16:10
+     */
+    public function lists()
+    {
+        return $this->dataLists(new WarehouseLists());
+    }
+
+
+    /**
+     * @notes 添加仓库信息
+     * @return \think\response\Json
+     * @author admin
+     * @date 2024/07/31 16:10
+     */
+    public function add()
+    {
+        $params = (new WarehouseValidate())->post()->goCheck('add');
+        $result = WarehouseLogic::add($params);
+        if (true === $result) {
+            return $this->success('添加成功', [], 1, 1);
+        }
+        return $this->fail(WarehouseLogic::getError());
+    }
+
+
+    /**
+     * @notes 编辑仓库信息
+     * @return \think\response\Json
+     * @author admin
+     * @date 2024/07/31 16:10
+     */
+    public function edit()
+    {
+        $params = (new WarehouseValidate())->post()->goCheck('edit');
+        $result = WarehouseLogic::edit($params);
+        if (true === $result) {
+            return $this->success('编辑成功', [], 1, 1);
+        }
+        return $this->fail(WarehouseLogic::getError());
+    }
+
+
+    /**
+     * @notes 删除仓库信息
+     * @return \think\response\Json
+     * @author admin
+     * @date 2024/07/31 16:10
+     */
+    public function delete()
+    {
+        $params = (new WarehouseValidate())->post()->goCheck('delete');
+        WarehouseLogic::delete($params);
+        return $this->success('删除成功', [], 1, 1);
+    }
+
+
+    /**
+     * @notes 获取仓库信息详情
+     * @return \think\response\Json
+     * @author admin
+     * @date 2024/07/31 16:10
+     */
+    public function detail()
+    {
+        $params = (new WarehouseValidate())->goCheck('detail');
+        $result = WarehouseLogic::detail($params);
+        return $this->data($result);
+    }
+
+
+}

app/admin/controller/warehouse_product/WarehouseProductController.php

@@ -0,0 +1,108 @@
+<?php
+
+namespace app\admin\controller\warehouse_product;
+
+
+use app\admin\controller\BaseAdminController;
+use app\admin\lists\warehouse_product\WarehouseProductLists;
+use app\admin\logic\warehouse_product\WarehouseProductLogic;
+use app\admin\validate\warehouse_product\WarehouseProductValidate;
+use app\common\model\warehouse_product\WarehouseProduct;
+
+/**
+ * 商品仓储信息控制器
+ * Class WarehouseProductController
+ * @package app\admin\controller\warehouse_product
+ */
+class WarehouseProductController extends BaseAdminController
+{
+
+
+    /**
+     * @notes 获取商品仓储信息列表
+     * @return \think\response\Json
+     * @author admin
+     * @date 2024/07/31 16:55
+     */
+    public function lists()
+    {
+        return $this->dataLists(new WarehouseProductLists());
+    }
+
+
+    /**
+     * @notes 添加商品仓储信息
+     * @return \think\response\Json
+     * @author admin
+     * @date 2024/07/31 16:55
+     */
+    public function add()
+    {
+        $params = (new WarehouseProductValidate())->post()->goCheck('add');
+        $params['admin_id']=$this->adminId;
+        $result = WarehouseProductLogic::add($params);
+        if (true === $result) {
+            return $this->success('添加成功', [], 1, 1);
+        }
+        return $this->fail(WarehouseProductLogic::getError());
+    }
+
+
+    /**
+     * @notes 编辑商品仓储信息
+     * @return \think\response\Json
+     * @author admin
+     * @date 2024/07/31 16:55
+     */
+    public function edit()
+    {
+        $params = (new WarehouseProductValidate())->post()->goCheck('edit');
+        $params['admin_id']=$this->adminId;
+        $result = WarehouseProductLogic::edit($params);
+        if (true === $result) {
+            return $this->success('编辑成功', [], 1, 1);
+        }
+        return $this->fail(WarehouseProductLogic::getError());
+    }
+
+
+    /**
+     * @notes 删除商品仓储信息
+     * @return \think\response\Json
+     * @author admin
+     * @date 2024/07/31 16:55
+     */
+    public function delete()
+    {
+        $params = (new WarehouseProductValidate())->post()->goCheck('delete');
+        WarehouseProductLogic::delete($params);
+        return $this->success('删除成功', [], 1, 1);
+    }
+
+
+    /**
+     * @notes 获取商品仓储信息详情
+     * @return \think\response\Json
+     * @author admin
+     * @date 2024/07/31 16:55
+     */
+    public function detail()
+    {
+        $params = (new WarehouseProductValidate())->goCheck('detail');
+        $result = WarehouseProductLogic::detail($params);
+        return $this->data($result);
+    }
+
+    /**
+     * 确认操作
+     */
+    public function enter(){
+        $id=$this->request->post('id');
+        $result = WarehouseProductLogic::enter($id);
+        if (true === $result) {
+            return $this->success('编辑成功', [], 1, 1);
+        }
+        return $this->fail(WarehouseProductLogic::getError());
+        return $this->success($result);
+    }
+}

app/admin/controller/warehouse_product_storege/WarehouseProductStoregeController.php

@@ -0,0 +1,95 @@
+<?php
+
+namespace app\admin\controller\warehouse_product_storege;
+
+
+use app\admin\controller\BaseAdminController;
+use app\admin\lists\warehouse_product_storege\WarehouseProductStoregeLists;
+use app\admin\logic\warehouse_product_storege\WarehouseProductStoregeLogic;
+use app\admin\validate\warehouse_product_storege\WarehouseProductStoregeValidate;
+
+
+/**
+ * 仓库商品存储控制器
+ * Class WarehouseProductStoregeController
+ * @package app\admin\controller\warehouse_product_storege
+ */
+class WarehouseProductStoregeController extends BaseAdminController
+{
+
+
+    /**
+     * @notes 获取仓库商品存储列表
+     * @return \think\response\Json
+     * @author admin
+     * @date 2024/08/01 10:22
+     */
+    public function lists()
+    {
+        return $this->dataLists(new WarehouseProductStoregeLists());
+    }
+
+
+    // /**
+    //  * @notes 添加仓库商品存储
+    //  * @return \think\response\Json
+    //  * @author admin
+    //  * @date 2024/08/01 10:22
+    //  */
+    // public function add()
+    // {
+    //     $params = (new WarehouseProductStoregeValidate())->post()->goCheck('add');
+    //     $result = WarehouseProductStoregeLogic::add($params);
+    //     if (true === $result) {
+    //         return $this->success('添加成功', [], 1, 1);
+    //     }
+    //     return $this->fail(WarehouseProductStoregeLogic::getError());
+    // }
+
+
+    // /**
+    //  * @notes 编辑仓库商品存储
+    //  * @return \think\response\Json
+    //  * @author admin
+    //  * @date 2024/08/01 10:22
+    //  */
+    // public function edit()
+    // {
+    //     $params = (new WarehouseProductStoregeValidate())->post()->goCheck('edit');
+    //     $result = WarehouseProductStoregeLogic::edit($params);
+    //     if (true === $result) {
+    //         return $this->success('编辑成功', [], 1, 1);
+    //     }
+    //     return $this->fail(WarehouseProductStoregeLogic::getError());
+    // }
+
+
+    // /**
+    //  * @notes 删除仓库商品存储
+    //  * @return \think\response\Json
+    //  * @author admin
+    //  * @date 2024/08/01 10:22
+    //  */
+    // public function delete()
+    // {
+    //     $params = (new WarehouseProductStoregeValidate())->post()->goCheck('delete');
+    //     WarehouseProductStoregeLogic::delete($params);
+    //     return $this->success('删除成功', [], 1, 1);
+    // }
+
+
+    // /**
+    //  * @notes 获取仓库商品存储详情
+    //  * @return \think\response\Json
+    //  * @author admin
+    //  * @date 2024/08/01 10:22
+    //  */
+    // public function detail()
+    // {
+    //     $params = (new WarehouseProductStoregeValidate())->goCheck('detail');
+    //     $result = WarehouseProductStoregeLogic::detail($params);
+    //     return $this->data($result);
+    // }
+
+
+}

app/admin/lists/purchase_order/PurchaseOrderLists.php

@@ -0,0 +1,97 @@
+<?php
+
+namespace app\admin\lists\purchase_order;
+
+
+use app\admin\lists\BaseAdminDataLists;
+use app\common\lists\ListsSearchInterface;
+use app\common\model\purchase_order\PurchaseOrder;
+use app\common\model\system_store\SystemStore;
+
+/**
+ * 采购订单列表
+ * Class PurchaseOrderLists
+ * @package app\admin\lists\purchase_order
+ */
+class PurchaseOrderLists extends BaseAdminDataLists implements ListsSearchInterface
+{
+
+
+    /**
+     * @notes 设置搜索条件
+     * @return \string[][]
+     * @author admin
+     * @date 2024/05/31 17:09
+     */
+    public function setSearch(): array
+    {
+        return [
+            '=' => ['store_id', 'order_id', 'is_mer','storage'],
+        ];
+    }
+
+
+    /**
+     * @notes 获取采购订单列表
+     * @return array
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     * @author admin
+     * @date 2024/05/31 17:09
+     */
+    public function lists(): array
+    {
+        if($this->request->get('o_id')){
+            $arr=PurchaseOrder::where('id',$this->request->get('o_id'))->value('order_arr');
+            if($arr){
+                $this->searchWhere[]=['id','in',$arr];
+            }
+        }
+        return PurchaseOrder::where($this->searchWhere)
+            ->limit($this->limitOffset, $this->limitLength)
+            ->order(['id' => 'desc'])
+            ->select()->each(function ($item) {
+                if ($item->store_id) {
+                    $item->system_store = SystemStore::where('id',$item->store_id)->value('name');
+                } else {
+                    $item->system_store = '平台';
+                }
+                if ($item->is_mer == 1) {
+                    $item->mer_name = '商户';
+                } else {
+                    $item->mer_name = '平台';
+                }
+                if ($item->is_opurchase == 1) {
+                    $item->opurchase_name = '已采购';
+                } else {
+                    $item->opurchase_name = '未采购';
+                }
+                switch ($item->storage) {
+                    case 0:
+                        $item->storage_name = '未入库';
+                        break;
+                    case 1:
+                        $item->storage_name = '部分入库';
+                        break;
+                    case 2:
+                        $item->storage_name = '已入库';
+                        break;
+                    default:
+                        $item->storage_name = '未入库';
+                }
+            })->toArray();
+    }
+
+
+    /**
+     * @notes 获取采购订单数量
+     * @return int
+     * @author admin
+     * @date 2024/05/31 17:09
+     */
+    public function count(): int
+    {
+        return PurchaseOrder::where($this->searchWhere)->count();
+    }
+}

app/admin/lists/purchase_order_info/PurchaseOrderInfoLists.php

@@ -0,0 +1,85 @@
+<?php
+
+namespace app\admin\lists\purchase_order_info;
+
+
+use app\admin\lists\BaseAdminDataLists;
+use app\common\lists\ListsSearchInterface;
+use app\common\model\purchase_order_info\PurchaseOrderInfo;
+use app\common\model\store_product\StoreProduct;
+use app\common\model\store_product_unit\StoreProductUnit;
+use app\common\model\system_store\SystemStore;
+
+/**
+ * 采购订单详情表
+ * Class PurchaseOrderInfoLists
+ * @package app\admin\lists\purchase_order
+ */
+class PurchaseOrderInfoLists extends BaseAdminDataLists implements ListsSearchInterface
+{
+
+
+    /**
+     * @notes 设置搜索条件
+     * @return \string[][]
+     * @author admin
+     * @date 2024/05/31 17:09
+     */
+    public function setSearch(): array
+    {
+        return [
+            '=' => ['store_id', 'oid', ],
+        ];
+    }
+
+
+    /**
+     * @notes 获取采购订单列表
+     * @return array
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     * @author admin
+     * @date 2024/05/31 17:09
+     */
+    public function lists(): array
+    {
+        return PurchaseOrderInfo::where($this->searchWhere)
+            ->limit($this->limitOffset, $this->limitLength)
+            ->order(['id' => 'desc'])
+            ->select()->each(function ($item) {
+                $find=StoreProduct::where('id',$item->product_id)->field('store_info,unit,store_name,image')->find();
+                if($find){
+                    $item->store_name=$find->store_name;
+                    $item->unit_name=StoreProductUnit::where('id',$find->unit)->value('name');
+                    $item->store_info=$find->store_info;
+                    $item->image=$find->image;
+                }
+                switch ($item->storage) {
+                    case 0:
+                        $item->storage_name = '未入库';
+                        break;
+                    case 1:
+                        $item->storage_name = '部分入库';
+                        break;
+                    case 2:
+                        $item->storage_name = '已入库';
+                        break;
+                    default:
+                        $item->storage_name = '未入库';
+                }
+            })->toArray();
+    }
+
+
+    /**
+     * @notes 获取采购订单数量
+     * @return int
+     * @author admin
+     * @date 2024/05/31 17:09
+     */
+    public function count(): int
+    {
+        return PurchaseOrderInfo::where($this->searchWhere)->count();
+    }
+}

app/admin/lists/store_order_cart_info/StoreOrderCartInfoGroupLists.php

@@ -0,0 +1,122 @@
+<?php
+
+namespace app\admin\lists\store_order_cart_info;
+
+
+use app\admin\lists\BaseAdminDataLists;
+use app\common\enum\PayEnum;
+use app\common\lists\ListsExcelInterface;
+use app\common\lists\ListsSearchInterface;
+use app\common\model\store_branch_product\StoreBranchProduct;
+use app\common\model\store_category\StoreCategory;
+use app\common\model\store_order\StoreOrder;
+use app\common\model\store_order_cart_info\StoreOrderCartInfo;
+use app\common\model\store_product\StoreProduct;
+use app\common\model\store_product_unit\StoreProductUnit;
+use app\common\model\system_store\SystemStore;
+
+/**
+ * 订单购物详情列表
+ * Class StoreOrderCartInfoGroupLists
+ * @package app\admin\store_order_cart_info
+ */
+class StoreOrderCartInfoGroupLists extends BaseAdminDataLists implements ListsSearchInterface,ListsExcelInterface
+{
+
+    /**
+     * @notes 设置搜索条件
+     * @return \string[][]
+     * @author admin
+     * @date 2024/05/31 16:02
+     */
+    public function setSearch(): array
+    {
+        return [
+            'between_time' => 'create_time'
+        ];
+    }
+
+
+    /**
+     * @notes 获取订单购物详情列表
+     * @return array
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     * @author admin
+     * @date 2024/05/31 16:02
+     */
+    public function lists(): array
+    {
+
+        if($this->request->get('start_time')==''){
+            $this->searchWhere[]=['create_time','between',[strtotime(date('Y-m-d 00:00:00')),strtotime(date('Y-m-d 23:59:59'))]];
+        }
+        return StoreOrderCartInfo::where($this->searchWhere)
+            ->field('product_id,price,SUM(total_price) as total_price,SUM(cart_num) as cart_num')->group('product_id')
+            ->limit($this->limitOffset, $this->limitLength)
+            ->select()->each(function ($item) {
+                $find=StoreProduct::where('id',$item['product_id'])->field('image,unit,cate_id,store_name,store_info')->find();
+                if($find){
+                    $item['image']=$find['image'];//商品图片
+                    $item['store_name']=$find['store_name'];//商品名称
+                    $item['store_info']=$find['store_info'];//商品规格
+                    $item['unit_name'] = StoreProductUnit::where('id', $find['unit'])->value('name')??"";
+                    $item['cate_name'] = StoreCategory::where('id', $find['cate_id'])->value('name')??"";
+                }else{
+                    $item['image']='';//商品图片
+                    $item['store_name']='';//商品名称
+                    $item['store_info']='';//商品规格-(数据库叫商品简介)
+                    $item['unit_name']='';//
+                    $item['cate_name']='';//
+                    $item['system_store']='';//
+                }
+                return $item; //返回处理后的数据。
+            })
+            ->toArray();
+    }
+
+
+    /**
+     * @notes 获取订单购物详情数量
+     * @return int
+     * @author admin
+     * @date 2024/05/31 16:02
+     */
+    public function count(): int
+    {
+        return StoreOrderCartInfo::where($this->searchWhere)->group('product_id')->count();
+    }
+
+       /**
+     * @notes 导出文件名
+     * @return string
+     * @author 乔峰
+     * @date 2022/11/24 16:17
+     */
+    public function setFileName(): string
+    {
+        return '订单总商品统计';
+    }
+
+
+    /**
+     * @notes 导出字段
+     * @return string[]
+     * @author 乔峰
+     * @date 2022/11/24 16:17
+     */
+    public function setExcelFields(): array
+    {
+        $data=[
+            'store_name' => '商品名称',
+            'store_info' => '规格',
+            'unit_name' => '单位',
+            'cate_name' => '分类',
+            'cart_num' => '数量',
+            'price' => '单价',
+            'total_price' => '总价',
+        ];
+        return $data;
+    }
+}

app/admin/lists/store_order_cart_info/StoreOrderCartInfoTwoLists.php

@@ -0,0 +1,132 @@
+<?php
+
+namespace app\admin\lists\store_order_cart_info;
+
+
+use app\admin\lists\BaseAdminDataLists;
+use app\common\enum\PayEnum;
+use app\common\lists\ListsExcelInterface;
+use app\common\lists\ListsSearchInterface;
+use app\common\model\store_branch_product\StoreBranchProduct;
+use app\common\model\store_category\StoreCategory;
+use app\common\model\store_order\StoreOrder;
+use app\common\model\store_order_cart_info\StoreOrderCartInfo;
+use app\common\model\store_product\StoreProduct;
+use app\common\model\store_product_unit\StoreProductUnit;
+use app\common\model\system_store\SystemStore;
+
+/**
+ * 订单购物详情列表
+ * Class StoreOrderCartInfoTwoLists
+ * @package app\admin\store_order_cart_info
+ */
+class StoreOrderCartInfoTwoLists extends BaseAdminDataLists implements ListsSearchInterface, ListsExcelInterface
+{
+
+    /**
+     * @notes 设置搜索条件
+     * @return \string[][]
+     * @author admin
+     * @date 2024/05/31 16:02
+     */
+    public function setSearch(): array
+    {
+        return [
+            '=' => ['store_id'],
+            'between_time' => 'create_time'
+        ];
+    }
+
+
+    /**
+     * @notes 获取订单购物详情列表
+     * @return array
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     * @author admin
+     * @date 2024/05/31 16:02
+     */
+    public function lists(): array
+    {
+        if ($this->request->get('start_time') == '') {
+            $this->searchWhere[] = ['create_time', 'between', [strtotime(date('Y-m-d 00:00:00')), strtotime(date('Y-m-d 23:59:59'))]];
+        }
+        $query = StoreOrderCartInfo::where($this->searchWhere);
+        if ($this->request->get('is_group') == 1) {
+            $query->field('store_id,product_id,price,SUM(total_price) as total_price,SUM(cart_num) as cart_num')->group(['store_id', 'product_id']);
+        } else {
+            $query->field('store_id,product_id,price,total_price,cart_num');
+        }
+        return $query->limit($this->limitOffset, $this->limitLength)
+            ->select()->each(function ($item) {
+                $find = StoreProduct::where('id', $item['product_id'])->field('image,unit,cate_id,store_name,store_info')->find();
+                if ($find) {
+                    $item['image'] = $find['image']; //商品图片
+                    $item['store_name'] = $find['store_name']; //商品名称
+                    $item['store_info'] = $find['store_info']; //商品规格
+                    $item['unit_name'] = StoreProductUnit::where('id', $find['unit'])->value('name')??'';
+                    $item['cate_name'] = StoreCategory::where('id', $find['cate_id'])->value('name')??'';
+                    $item['system_store'] = SystemStore::where('id', $item['store_id'])->value('name')??'';
+                }else{
+                    $item['image']='';//商品图片
+                    $item['store_name']='';//商品名称
+                    $item['store_info']='';//商品规格-(数据库叫商品简介)
+                    $item['unit_name']='';//
+                    $item['cate_name']='';//
+                    $item['system_store']='';//
+                }
+                return $item; //返回处理后的数据。
+            })
+            ->toArray();
+    }
+
+
+    /**
+     * @notes 获取订单购物详情数量
+     * @return int
+     * @author admin
+     * @date 2024/05/31 16:02
+     */
+    public function count(): int
+    {
+        if ($this->request->get('is_group') == 1) {
+            return StoreOrderCartInfo::where($this->searchWhere)->group('product_id')->count();
+        } else {
+            return StoreOrderCartInfo::where($this->searchWhere)->count();
+        }
+    }
+
+    /**
+     * @notes 导出文件名
+     * @return string
+     * @author 乔峰
+     * @date 2022/11/24 16:17
+     */
+    public function setFileName(): string
+    {
+        return '订单商品统计';
+    }
+
+
+    /**
+     * @notes 导出字段
+     * @return string[]
+     * @author 乔峰
+     * @date 2022/11/24 16:17
+     */
+    public function setExcelFields(): array
+    {
+        $data = [
+            'system_store' => '门店',
+            'store_name' => '商品名称',
+            'store_info' => '规格',
+            'unit_name' => '单位',
+            'cate_name' => '分类',
+            'cart_num' => '数量',
+            'price' => '单价',
+            'total_price' => '总价',
+        ];
+        return $data;
+    }
+}

app/admin/lists/system_store_storage/SystemStoreStorageLists.php

@@ -59,8 +59,8 @@ class SystemStoreStorageLists extends BaseAdminDataLists implements ListsSearchI
                     $item['staff_name'] = '无';
                 }
                 $find=StoreProduct::where('id',$item['product_id'])->field('store_name,image')->find();
-                $item['store_name']=$find['store_name'];
+                $item['store_name']=$find['store_name']??'';
-                $item['image']=$find['image'];
+                $item['image']=$find['image']??'';
                 return $item;
             })
             ->toArray();

app/admin/lists/warehouse/WarehouseLists.php

@@ -0,0 +1,65 @@
+<?php
+
+namespace app\admin\lists\warehouse;
+
+
+use app\admin\lists\BaseAdminDataLists;
+use app\common\model\warehouse\Warehouse;
+use app\common\lists\ListsSearchInterface;
+
+
+/**
+ * 仓库信息列表
+ * Class WarehouseLists
+ * @package app\admin\listswarehouse
+ */
+class WarehouseLists extends BaseAdminDataLists implements ListsSearchInterface
+{
+
+
+    /**
+     * @notes 设置搜索条件
+     * @return \string[][]
+     * @author admin
+     * @date 2024/07/31 16:10
+     */
+    public function setSearch(): array
+    {
+        return [
+            '=' => ['name', 'contacts', 'tel'],
+        ];
+    }
+
+
+    /**
+     * @notes 获取仓库信息列表
+     * @return array
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     * @author admin
+     * @date 2024/07/31 16:10
+     */
+    public function lists(): array
+    {
+        return Warehouse::where($this->searchWhere)
+            ->field(['id', 'name', 'code', 'contacts', 'tel', 'address', 'notes', 'sort'])
+            ->limit($this->limitOffset, $this->limitLength)
+            ->order(['id' => 'desc'])
+            ->select()
+            ->toArray();
+    }
+
+
+    /**
+     * @notes 获取仓库信息数量
+     * @return int
+     * @author admin
+     * @date 2024/07/31 16:10
+     */
+    public function count(): int
+    {
+        return Warehouse::where($this->searchWhere)->count();
+    }
+
+}

app/admin/lists/warehouse_product/WarehouseProductLists.php

@@ -0,0 +1,97 @@
+<?php
+
+namespace app\admin\lists\warehouse_product;
+
+
+use app\admin\lists\BaseAdminDataLists;
+use app\common\model\warehouse_product\WarehouseProduct;
+use app\common\lists\ListsSearchInterface;
+use app\common\model\auth\Admin;
+use app\common\model\store_product\StoreProduct;
+use app\common\model\warehouse\Warehouse;
+
+/**
+ * 商品仓储信息列表
+ * Class WarehouseProductLists
+ * @package app\admin\listswarehouse_product
+ */
+class WarehouseProductLists extends BaseAdminDataLists implements ListsSearchInterface
+{
+
+
+    /**
+     * @notes 设置搜索条件
+     * @return \string[][]
+     * @author admin
+     * @date 2024/07/31 16:55
+     */
+    public function setSearch(): array
+    {
+        return [
+            '=' => ['warehouse_id', 'product_id', 'financial_pm'],
+        ];
+    }
+
+
+    /**
+     * @notes 获取商品仓储信息列表
+     * @return array
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     * @author admin
+     * @date 2024/07/31 16:55
+     */
+    public function lists(): array
+    {
+        return WarehouseProduct::where($this->searchWhere)
+            ->field(['id', 'admin_id','warehouse_id', 'product_id', 'financial_pm', 'batch', 'nums', 'price', 'total_price', 'manufacture','expiration_date','status','mark'])
+            ->limit($this->limitOffset, $this->limitLength)
+            ->order(['id' => 'desc'])
+            ->select()->each(function ($item){
+                if($item->financial_pm==0){
+                    $item->financial_pm_name='出库';
+                }else{
+                    $item->financial_pm_name='入库';
+                }
+                if($item->status==0){
+                    $item->status_name='未确认';
+                }elseif($item->status==1){
+                    $item->status_name='已确认';
+                }else{
+                    $item->status_name='库存不足';
+                }
+                if($item->admin_id){
+                    $item->admin_name=Admin::where('id',$item->admin_id)->value('name');
+                }else{
+                    $item->admin_name='';
+                }
+                if($item->product_id){
+                    $item->store_name=StoreProduct::where('id',$item->product_id)->value('store_name');
+                }else{
+                    $item->store_name='';
+                }
+                if($item->warehouse_id){
+                    $item->warehouse_name=Warehouse::where('id',$item->warehouse_id)->value('name');
+                }else{
+                    $item->warehouse_name='';
+                }
+                $item->expiration_date=$item->expiration_date?date('Y-m-d',$item->expiration_date):'';
+                $item->manufacture=$item->manufacture?date('Y-m-d',$item->manufacture):'';
+            }) 
+            ->toArray();
+    }
+
+
+    /**
+     * @notes 获取商品仓储信息数量
+     * @return int
+     * @author admin
+     * @date 2024/07/31 16:55
+     */
+    public function count(): int
+    {
+        return WarehouseProduct::where($this->searchWhere)->count();
+    }
+
+}

app/admin/lists/warehouse_product_storege/WarehouseProductStoregeLists.php

@@ -0,0 +1,85 @@
+<?php
+
+namespace app\admin\lists\warehouse_product_storege;
+
+
+use app\admin\lists\BaseAdminDataLists;
+use app\common\model\warehouse_product_storege\WarehouseProductStorege;
+use app\common\lists\ListsSearchInterface;
+use app\common\model\store_category\StoreCategory;
+use app\common\model\store_product\StoreProduct;
+use app\common\model\store_product_unit\StoreProductUnit;
+use app\common\model\warehouse\Warehouse;
+
+/**
+ * 仓库商品存储列表
+ * Class WarehouseProductStoregeLists
+ * @package app\admin\listswarehouse_product_storege
+ */
+class WarehouseProductStoregeLists extends BaseAdminDataLists implements ListsSearchInterface
+{
+
+
+    /**
+     * @notes 设置搜索条件
+     * @return \string[][]
+     * @author admin
+     * @date 2024/08/01 10:22
+     */
+    public function setSearch(): array
+    {
+        return [
+            '=' => ['warehouse_id'],
+        ];
+    }
+
+
+    /**
+     * @notes 获取仓库商品存储列表
+     * @return array
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     * @author admin
+     * @date 2024/08/01 10:22
+     */
+    public function lists(): array
+    {
+        return WarehouseProductStorege::where($this->searchWhere)
+            ->field(['id', 'warehouse_id', 'product_id', 'nums', 'price', 'total_price', 'status'])
+            ->limit($this->limitOffset, $this->limitLength)
+            ->order(['id' => 'desc'])
+            ->select()->each(function ($item){
+                $item->warehouse_name = Warehouse::where('id',$item->warehouse_id)->value('name');
+                $find= StoreProduct::where('id',$item->product_id)->find();
+                if($find){
+                    $item->store_name = $find->store_name;
+                    $item->image = $find->image;
+                    $item->bar_code = $find->bar_code;
+                    $item->price = $find->price;
+                    $item->cost = $find->cost;
+                    $item->purchase = $find->purchase;
+                    $item->store_info = $find->store_info;
+                    $item->rose = $find->rose;
+                    $item['unit_name'] = StoreProductUnit::where('id', $find['unit'])->value('name');
+                    $item['cate_name'] = StoreCategory::where('id', $find['cate_id'])->value('name');
+                }
+                $item['stock']=$item['nums'];
+                return $item;
+            }) 
+            ->toArray();
+    }
+
+
+    /**
+     * @notes 获取仓库商品存储数量
+     * @return int
+     * @author admin
+     * @date 2024/08/01 10:22
+     */
+    public function count(): int
+    {
+        return WarehouseProductStorege::where($this->searchWhere)->count();
+    }
+
+}

app/admin/logic/purchase_order/PurchaseOrderLogic.php

@@ -0,0 +1,172 @@
+<?php
+
+namespace app\admin\logic\purchase_order;
+
+
+use app\common\model\purchase_order\PurchaseOrder;
+use app\common\logic\BaseLogic;
+use app\common\model\purchase_order_info\PurchaseOrderInfo;
+use app\common\model\store_order\StoreOrder;
+use app\common\model\store_order_cart_info\StoreOrderCartInfo;
+use app\common\model\system_store\SystemStore;
+use think\facade\Db;
+
+
+/**
+ * 采购订单逻辑
+ * Class PurchaseOrderLogic
+ * @package app\admin\logic\purchase_order
+ */
+class PurchaseOrderLogic extends BaseLogic
+{
+
+
+    /**
+     * @notes 合并今日商户订单
+     * @param array $params
+     * @return bool
+     * @author admin
+     * @date 2024/08/01 16:32
+     */
+    public static function StoreTodayOrder(): bool
+    {
+        Db::startTrans();
+        try {
+            $store_arr = StoreOrder::where(['paid' => 1, 'refund_status' => 0])->whereDay('create_time')->group('store_id')->column('store_id');
+            $purchaseOrderInfo = new PurchaseOrderInfo();
+            foreach ($store_arr as $store_id) {
+                $purchase_order_info = [];
+                $order_arr = StoreOrder::where(['paid' => 1, 'refund_status' => 0, 'store_id' => $store_id])->whereDay('create_time')->column('id');
+                $price = StoreOrder::where(['paid' => 1, 'refund_status' => 0, 'store_id' => $store_id])->whereDay('create_time')->field('SUM(pay_price) as pay_price,SUM(total_price) as total_price')->find();
+                $data = [
+                    'store_id' => $store_id,
+                    'order_arr' => json_encode($order_arr),
+                    'order_id' => getNewOrderId('CG'),
+                    'total' => $price['total_price'],
+                    'actual' => $price['pay_price'],
+                    'money' => $price['pay_price'],
+                    'paid' => 1,
+                    'is_mer' => 1,
+                    'create_time' => time(),
+                    'update_time' => time(),
+                ];
+                $res = PurchaseOrder::create($data);
+                $info = StoreOrderCartInfo::where('oid', 'in', $order_arr)->field('store_id, product_id,price,SUM(total_price) as total_price, SUM(cart_num) as cart_num')->group('store_id, product_id')->select();
+                foreach ($info as $item) {
+                    $arr['oid'] = $res['id'];
+                    $arr['store_id'] = $item['store_id'];
+                    $arr['product_id'] = $item['product_id'];
+                    $arr['price'] = $item['price'];
+                    $arr['total_price'] = $item['total_price'];
+                    $arr['cart_num'] = $item['cart_num'];
+                    $arr['status'] = 1;
+                    $purchase_order_info[] = $arr;
+                }
+                $purchaseOrderInfo->saveAll($purchase_order_info);
+            }
+            Db::commit();
+            return true;
+        } catch (\Exception $e) {
+            Db::rollback();
+            self::setError($e->getMessage());
+            return false;
+        }
+    }
+
+    /**
+     * @notes 合并今日平台订单
+     * @param array $params
+     * @return bool
+     * @author admin
+     * @date 2024/08/01 16:32
+     */
+    public static function platformTodayOrder()
+    {
+        Db::startTrans();
+        try {
+            $purchaseOrderInfo = new PurchaseOrderInfo();
+            $purchase_order_info=[];
+            $order_arr = PurchaseOrder::whereDay('create_time')->where('is_mer',1)->column('id');
+            $price = PurchaseOrder::whereDay('create_time')->field('SUM(actual) as pay_price,SUM(total) as total_price')->find();
+            $data = [
+                'store_id' => 0,
+                'order_arr' => json_encode($order_arr),
+                'order_id' => getNewOrderId('PT'),
+                'total' => $price['total_price'],
+                'actual' => $price['pay_price'],
+                'money' => $price['pay_price'],
+                'paid' => 1,
+                'is_mer' => 2,
+                'create_time' => time(),
+                'update_time' => time(),
+            ];
+            $res = PurchaseOrder::create($data);
+            $info = PurchaseOrderInfo::where('oid', 'in', $order_arr)->field('store_id, product_id,price,SUM(total_price) as total_price, SUM(cart_num) as cart_num')->group('store_id, product_id')->select();
+            foreach ($info as $item) {
+                $arr['oid'] = $res['id'];
+                $arr['store_id'] = $item['store_id'];
+                $arr['product_id'] = $item['product_id'];
+                $arr['price'] = $item['price'];
+                $arr['total_price'] = $item['total_price'];
+                $arr['cart_num'] = $item['cart_num'];
+                $arr['status'] = 1;
+                $purchase_order_info[] = $arr;
+            }
+            $purchaseOrderInfo->saveAll($purchase_order_info);
+
+            Db::commit();
+            return true;
+        } catch (\Exception $e) {
+            Db::rollback();
+            d($e);
+            self::setError($e->getMessage());
+            return false;
+        }
+    }
+
+    /**
+     * @notes 删除采购订单
+     * @param array $params
+     * @return bool
+     * @author admin
+     * @date 2024/08/01 16:32
+     */
+    public static function delete(array $params): bool
+    {
+        return PurchaseOrder::destroy($params['id']);
+    }
+
+
+    /**
+     * @notes 获取采购订单详情
+     * @param $params
+     * @return array
+     * @author admin
+     * @date 2024/08/01 16:32
+     */
+    public static function detail($id): array
+    {
+        $data= PurchaseOrder::findOrEmpty($id)->toArray();
+        if($data){
+            if($data['store_id']){
+                $data['system_store']=SystemStore::where('id',$data['store_id'])->value('name');
+            }else{
+                $data['system_store']='平台';
+            }
+            switch ($data['storage']) {
+                case 0:
+                    $data['storage_name'] = '未入库';
+                    break;
+                case 1:
+                    $data['storage_name'] = '部分入库';
+                    break;
+                case 2:
+                    $data['storage_name'] = '已入库';
+                    break;
+                default:
+                    $data['storage_name'] = '未入库';
+            }
+        }
+        return $data;
+    }
+}

app/admin/logic/warehouse/WarehouseLogic.php

@@ -0,0 +1,106 @@
+<?php
+
+namespace app\admin\logic\warehouse;
+
+
+use app\common\model\warehouse\Warehouse;
+use app\common\logic\BaseLogic;
+use think\facade\Db;
+
+
+/**
+ * 仓库信息逻辑
+ * Class WarehouseLogic
+ * @package app\admin\logic\warehouse
+ */
+class WarehouseLogic extends BaseLogic
+{
+
+
+    /**
+     * @notes 添加仓库信息
+     * @param array $params
+     * @return bool
+     * @author admin
+     * @date 2024/07/31 16:10
+     */
+    public static function add(array $params): bool
+    {
+        Db::startTrans();
+        try {
+            Warehouse::create([
+                'name' => $params['name'],
+                'code' => $params['code'],
+                'contacts' => $params['contacts'],
+                'tel' => $params['tel'],
+                'address' => $params['address'],
+                'notes' => $params['notes'],
+                'sort' => $params['sort']
+            ]);
+
+            Db::commit();
+            return true;
+        } catch (\Exception $e) {
+            Db::rollback();
+            self::setError($e->getMessage());
+            return false;
+        }
+    }
+
+
+    /**
+     * @notes 编辑仓库信息
+     * @param array $params
+     * @return bool
+     * @author admin
+     * @date 2024/07/31 16:10
+     */
+    public static function edit(array $params): bool
+    {
+        Db::startTrans();
+        try {
+            Warehouse::where('id', $params['id'])->update([
+                'name' => $params['name'],
+                'code' => $params['code'],
+                'contacts' => $params['contacts'],
+                'tel' => $params['tel'],
+                'address' => $params['address'],
+                'notes' => $params['notes'],
+                'sort' => $params['sort']
+            ]);
+
+            Db::commit();
+            return true;
+        } catch (\Exception $e) {
+            Db::rollback();
+            self::setError($e->getMessage());
+            return false;
+        }
+    }
+
+
+    /**
+     * @notes 删除仓库信息
+     * @param array $params
+     * @return bool
+     * @author admin
+     * @date 2024/07/31 16:10
+     */
+    public static function delete(array $params): bool
+    {
+        return Warehouse::destroy($params['id']);
+    }
+
+
+    /**
+     * @notes 获取仓库信息详情
+     * @param $params
+     * @return array
+     * @author admin
+     * @date 2024/07/31 16:10
+     */
+    public static function detail($params): array
+    {
+        return Warehouse::findOrEmpty($params['id'])->toArray();
+    }
+}

app/admin/logic/warehouse_product/WarehouseProductLogic.php

@@ -0,0 +1,178 @@
+<?php
+
+namespace app\admin\logic\warehouse_product;
+
+
+use app\common\model\warehouse_product\WarehouseProduct;
+use app\common\logic\BaseLogic;
+use app\common\model\store_product\StoreProduct;
+use app\common\model\warehouse_product_storege\WarehouseProductStorege;
+use support\Log;
+use think\facade\Db;
+
+
+/**
+ * 商品仓储信息逻辑
+ * Class WarehouseProductLogic
+ * @package app\admin\logic\warehouse_product
+ */
+class WarehouseProductLogic extends BaseLogic
+{
+
+
+    /**
+     * @notes 添加商品仓储信息
+     * @param array $params
+     * @return bool
+     * @author admin
+     * @date 2024/07/31 16:55
+     */
+    public static function add(array $params): bool
+    {
+        Db::startTrans();
+        try {
+            $data=[
+                'warehouse_id' => $params['warehouse_id'],
+                'product_id' => $params['product_id'],
+                'financial_pm' => $params['financial_pm'],
+                'batch' => $params['batch'],
+                'nums' => $params['nums'],
+                'price' => $params['price']??'',
+                'total_price' => $params['total_price']??'',
+                'admin_id' => $params['admin_id'],
+                'code' => $params['code']??'',
+                'status' => $params['status']??0,
+                'mark' => $params['mark']??'',
+            ];
+            if(isset($params['manufacture']) &&$params['manufacture']!=''){
+                $data['manufacture']=strtotime($params['manufacture']);
+            }
+            if(isset($params['expiration_date']) &&$params['expiration_date']!=''){
+                $data['expiration_date']=strtotime($params['expiration_date']);
+            }
+            $res=WarehouseProduct::create($data);
+            self::enter($res['id'],$params['financial_pm']);
+            Db::commit();
+            return true;
+        } catch (\Exception $e) {
+            Db::rollback();
+            self::setError($e->getMessage());
+            return false;
+        }
+    }
+
+
+    /**
+     * @notes 编辑商品仓储信息
+     * @param array $params
+     * @return bool
+     * @author admin
+     * @date 2024/07/31 16:55
+     */
+    public static function edit(array $params): bool
+    {
+        Db::startTrans();
+        try {
+            $data=[
+                'warehouse_id' => $params['warehouse_id'],
+                'product_id' => $params['product_id'],
+                'financial_pm' => $params['financial_pm'],
+                'batch' => $params['batch'],
+                'nums' => $params['nums'],
+                'price' => $params['price'],
+                'admin_id' => $params['admin_id'],
+                'total_price' => $params['total_price'],
+                'code' => $params['code'],
+            ];
+            if(isset($params['manufacture']) &&$params['manufacture']!=''){
+                $data['manufacture']=strtotime($params['manufacture']);
+            }
+            if(isset($params['expiration_date']) &&$params['expiration_date']!=''){
+                $data['expiration_date']=strtotime($params['expiration_date']);
+            }
+            WarehouseProduct::where('id', $params['id'])->update($data);
+
+            Db::commit();
+            return true;
+        } catch (\Exception $e) {
+            Db::rollback();
+            self::setError($e->getMessage());
+            return false;
+        }
+    }
+    
+    /**
+     * @notes 确认商品仓储信息
+     * @param array $params
+     * @author admin
+     * @date 2024/07/31 16:55
+     */
+    public static function enter($id,$financial_pm=0)
+    {
+        Db::startTrans();
+        try {
+            $find=WarehouseProduct::where('id',$id)->find();
+            $find->status=1;
+            $find->save();
+            $storege=WarehouseProductStorege::where('warehouse_id',$find['warehouse_id'])->where('product_id',$find['product_id'])->find();
+            if($financial_pm==0){
+                StoreProduct::where('id',$find['product_id'])->dec('stock',$find['nums'])->update();
+            }else{
+                StoreProduct::where('id',$find['product_id'])->inc('stock',$find['nums'])->update();
+            }
+            if($storege){
+                if($financial_pm==0){
+                    $storege->nums=bcsub($storege->nums,$find['nums']);
+                }else{
+                    $storege->nums=bcadd($storege->nums,$find['nums']);
+                }
+                $storege->save();
+
+            }else{
+                WarehouseProductStorege::create([
+                    'warehouse_id' => $find['warehouse_id'],
+                    'product_id' => $find['product_id'],
+                    'nums' => $find['nums'],
+                ]);
+            }
+            Db::commit();
+            return true;
+        } catch (\Exception $e) {
+            Db::rollback();
+            self::setError($e->getMessage());
+            return false;
+        }
+    }
+
+
+    /**
+     * @notes 删除商品仓储信息
+     * @param array $params
+     * @return bool
+     * @author admin
+     * @date 2024/07/31 16:55
+     */
+    public static function delete(array $params): bool
+    {
+        return WarehouseProduct::destroy($params['id']);
+    }
+
+
+    /**
+     * @notes 获取商品仓储信息详情
+     * @param $params
+     * @return array
+     * @author admin
+     * @date 2024/07/31 16:55
+     */
+    public static function detail($params): array
+    {
+        $data= WarehouseProduct::findOrEmpty($params['id'])->toArray();
+        if($data){
+            $data['manufacture']=date('Y-m-d',$data['manufacture']);
+            $data['expiration_date']=date('Y-m-d',$data['expiration_date']);
+        
+        }
+        return $data;
+    }
+}

app/admin/logic/warehouse_product_storege/WarehouseProductStoregeLogic.php

@@ -0,0 +1,104 @@
+<?php
+
+namespace app\admin\logic\warehouse_product_storege;
+
+
+use app\common\model\warehouse_product_storege\WarehouseProductStorege;
+use app\common\logic\BaseLogic;
+use think\facade\Db;
+
+
+/**
+ * 仓库商品存储逻辑
+ * Class WarehouseProductStoregeLogic
+ * @package app\admin\logic\warehouse_product_storege
+ */
+class WarehouseProductStoregeLogic extends BaseLogic
+{
+
+
+    /**
+     * @notes 添加仓库商品存储
+     * @param array $params
+     * @return bool
+     * @author admin
+     * @date 2024/08/01 10:22
+     */
+    public static function add(array $params): bool
+    {
+        Db::startTrans();
+        try {
+            WarehouseProductStorege::create([
+                'warehouse_id' => $params['warehouse_id'],
+                'product_id' => $params['product_id'],
+                'nums' => $params['nums'],
+                'price' => $params['price'],
+                'total_price' => $params['total_price'],
+                'status' => $params['status']
+            ]);
+
+            Db::commit();
+            return true;
+        } catch (\Exception $e) {
+            Db::rollback();
+            self::setError($e->getMessage());
+            return false;
+        }
+    }
+
+
+    /**
+     * @notes 编辑仓库商品存储
+     * @param array $params
+     * @return bool
+     * @author admin
+     * @date 2024/08/01 10:22
+     */
+    public static function edit(array $params): bool
+    {
+        Db::startTrans();
+        try {
+            WarehouseProductStorege::where('id', $params['id'])->update([
+                'warehouse_id' => $params['warehouse_id'],
+                'product_id' => $params['product_id'],
+                'nums' => $params['nums'],
+                'price' => $params['price'],
+                'total_price' => $params['total_price'],
+                'status' => $params['status']
+            ]);
+
+            Db::commit();
+            return true;
+        } catch (\Exception $e) {
+            Db::rollback();
+            self::setError($e->getMessage());
+            return false;
+        }
+    }
+
+
+    /**
+     * @notes 删除仓库商品存储
+     * @param array $params
+     * @return bool
+     * @author admin
+     * @date 2024/08/01 10:22
+     */
+    public static function delete(array $params): bool
+    {
+        return WarehouseProductStorege::destroy($params['id']);
+    }
+
+
+    /**
+     * @notes 获取仓库商品存储详情
+     * @param $params
+     * @return array
+     * @author admin
+     * @date 2024/08/01 10:22
+     */
+    public static function detail($params): array
+    {
+        return WarehouseProductStorege::findOrEmpty($params['id'])->toArray();
+    }
+}

app/admin/validate/purchase_order/PurchaseOrderValidate.php

@@ -0,0 +1,86 @@
+<?php
+
+namespace app\admin\validate\purchase_order;
+
+
+use app\common\validate\BaseValidate;
+
+
+/**
+ * 采购订单验证器
+ * Class PurchaseOrderValidate
+ * @package app\admin\validate\purchase_order
+ */
+class PurchaseOrderValidate extends BaseValidate
+{
+
+     /**
+      * 设置校验规则
+      * @var string[]
+      */
+    protected $rule = [
+        'id' => 'require',
+        'store_id' => 'require',
+        'order_id' => 'require',
+    ];
+
+
+    /**
+     * 参数描述
+     * @var string[]
+     */
+    protected $field = [
+        'id' => 'id',
+        'store_id' => '所属商户',
+        'order_id' => '单据编号',
+    ];
+
+
+    /**
+     * @notes 添加场景
+     * @return PurchaseOrderValidate
+     * @author admin
+     * @date 2024/08/01 16:32
+     */
+    public function sceneAdd()
+    {
+        return $this->only(['store_id','order_id']);
+    }
+
+
+    /**
+     * @notes 编辑场景
+     * @return PurchaseOrderValidate
+     * @author admin
+     * @date 2024/08/01 16:32
+     */
+    public function sceneEdit()
+    {
+        return $this->only(['id','store_id','order_id']);
+    }
+
+
+    /**
+     * @notes 删除场景
+     * @return PurchaseOrderValidate
+     * @author admin
+     * @date 2024/08/01 16:32
+     */
+    public function sceneDelete()
+    {
+        return $this->only(['id']);
+    }
+
+
+    /**
+     * @notes 详情场景
+     * @return PurchaseOrderValidate
+     * @author admin
+     * @date 2024/08/01 16:32
+     */
+    public function sceneDetail()
+    {
+        return $this->only(['id']);
+    }
+
+}

app/admin/validate/warehouse/WarehouseValidate.php

@@ -0,0 +1,84 @@
+<?php
+
+namespace app\admin\validate\warehouse;
+
+
+use app\common\validate\BaseValidate;
+
+
+/**
+ * 仓库信息验证器
+ * Class WarehouseValidate
+ * @package app\admin\validate\warehouse
+ */
+class WarehouseValidate extends BaseValidate
+{
+
+     /**
+      * 设置校验规则
+      * @var string[]
+      */
+    protected $rule = [
+        'id' => 'require',
+        'name' => 'require',
+    ];
+
+
+    /**
+     * 参数描述
+     * @var string[]
+     */
+    protected $field = [
+        'id' => 'id',
+        'name' => '仓库名称',
+    ];
+
+
+    /**
+     * @notes 添加场景
+     * @return WarehouseValidate
+     * @author admin
+     * @date 2024/07/31 16:10
+     */
+    public function sceneAdd()
+    {
+        return $this->only(['name']);
+    }
+
+
+    /**
+     * @notes 编辑场景
+     * @return WarehouseValidate
+     * @author admin
+     * @date 2024/07/31 16:10
+     */
+    public function sceneEdit()
+    {
+        return $this->only(['id','name']);
+    }
+
+
+    /**
+     * @notes 删除场景
+     * @return WarehouseValidate
+     * @author admin
+     * @date 2024/07/31 16:10
+     */
+    public function sceneDelete()
+    {
+        return $this->only(['id']);
+    }
+
+
+    /**
+     * @notes 详情场景
+     * @return WarehouseValidate
+     * @author admin
+     * @date 2024/07/31 16:10
+     */
+    public function sceneDetail()
+    {
+        return $this->only(['id']);
+    }
+
+}

app/admin/validate/warehouse_product/WarehouseProductValidate.php

@@ -0,0 +1,98 @@
+<?php
+
+namespace app\admin\validate\warehouse_product;
+
+
+use app\common\validate\BaseValidate;
+
+
+/**
+ * 商品仓储信息验证器
+ * Class WarehouseProductValidate
+ * @package app\admin\validate\warehouse_product
+ */
+class WarehouseProductValidate extends BaseValidate
+{
+
+     /**
+      * 设置校验规则
+      * @var string[]
+      */
+    protected $rule = [
+        'id' => 'require',
+        'warehouse_id' => 'require',
+        'product_id' => 'require',
+        'financial_pm' => 'require',
+        'batch' => 'require',
+        'nums' => 'require',
+        'price' => 'require',
+        'total_price' => 'require',
+        'status' => 'require',
+    ];
+
+
+    /**
+     * 参数描述
+     * @var string[]
+     */
+    protected $field = [
+        'id' => 'id',
+        'warehouse_id' => '仓库ID',
+        'product_id' => '商品ID',
+        'financial_pm' => '0 = 出库 1 = 获得',
+        'batch' => '批次',
+        'nums' => '数量',
+        'price' => '价格',
+        'total_price' => '总价',
+        'status' => '状态',
+    ];
+
+
+    /**
+     * @notes 添加场景
+     * @return WarehouseProductValidate
+     * @author admin
+     * @date 2024/07/31 16:55
+     */
+    public function sceneAdd()
+    {
+        return $this->only(['warehouse_id','product_id','financial_pm','batch','nums','price','total_price']);
+    }
+
+
+    /**
+     * @notes 编辑场景
+     * @return WarehouseProductValidate
+     * @author admin
+     * @date 2024/07/31 16:55
+     */
+    public function sceneEdit()
+    {
+        return $this->only(['id','warehouse_id','product_id','financial_pm','batch','nums','price','total_price']);
+    }
+
+
+    /**
+     * @notes 删除场景
+     * @return WarehouseProductValidate
+     * @author admin
+     * @date 2024/07/31 16:55
+     */
+    public function sceneDelete()
+    {
+        return $this->only(['id']);
+    }
+
+
+    /**
+     * @notes 详情场景
+     * @return WarehouseProductValidate
+     * @author admin
+     * @date 2024/07/31 16:55
+     */
+    public function sceneDetail()
+    {
+        return $this->only(['id']);
+    }
+
+}

app/admin/validate/warehouse_product_storege/WarehouseProductStoregeValidate.php

@@ -0,0 +1,94 @@
+<?php
+
+namespace app\admin\validate\warehouse_product_storege;
+
+
+use app\common\validate\BaseValidate;
+
+
+/**
+ * 仓库商品存储验证器
+ * Class WarehouseProductStoregeValidate
+ * @package app\admin\validate\warehouse_product_storege
+ */
+class WarehouseProductStoregeValidate extends BaseValidate
+{
+
+     /**
+      * 设置校验规则
+      * @var string[]
+      */
+    protected $rule = [
+        'id' => 'require',
+        'warehouse_id' => 'require',
+        'product_id' => 'require',
+        'nums' => 'require',
+        'price' => 'require',
+        'total_price' => 'require',
+        'status' => 'require',
+    ];
+
+
+    /**
+     * 参数描述
+     * @var string[]
+     */
+    protected $field = [
+        'id' => 'id',
+        'warehouse_id' => '仓库ID',
+        'product_id' => '商品ID',
+        'nums' => '数量',
+        'price' => '价格',
+        'total_price' => '价格',
+        'status' => '状态',
+    ];
+
+
+    /**
+     * @notes 添加场景
+     * @return WarehouseProductStoregeValidate
+     * @author admin
+     * @date 2024/08/01 10:22
+     */
+    public function sceneAdd()
+    {
+        return $this->only(['warehouse_id','product_id','nums','price','total_price','status']);
+    }
+
+
+    /**
+     * @notes 编辑场景
+     * @return WarehouseProductStoregeValidate
+     * @author admin
+     * @date 2024/08/01 10:22
+     */
+    public function sceneEdit()
+    {
+        return $this->only(['id','warehouse_id','product_id','nums','price','total_price','status']);
+    }
+
+
+    /**
+     * @notes 删除场景
+     * @return WarehouseProductStoregeValidate
+     * @author admin
+     * @date 2024/08/01 10:22
+     */
+    public function sceneDelete()
+    {
+        return $this->only(['id']);
+    }
+
+
+    /**
+     * @notes 详情场景
+     * @return WarehouseProductStoregeValidate
+     * @author admin
+     * @date 2024/08/01 10:22
+     */
+    public function sceneDetail()
+    {
+        return $this->only(['id']);
+    }
+
+}

app/common/model/purchase_order/PurchaseOrder.php

@@ -0,0 +1,22 @@
+<?php
+
+namespace app\common\model\purchase_order;
+
+
+use app\common\model\BaseModel;
+use think\model\concern\SoftDelete;
+
+
+/**
+ * 采购订单
+ * Class PurchaseOrder
+ * @package app\common\model\purchase_order
+ */
+class PurchaseOrder extends BaseModel
+{
+    use SoftDelete;
+    protected $name = 'purchase_order';
+    protected $deleteTime = 'delete_time';
+    protected $json = ['order_arr'];
+    
+}

app/common/model/purchase_order_info/PurchaseOrderInfo.php

@@ -0,0 +1,22 @@
+<?php
+
+namespace app\common\model\purchase_order_info;
+
+
+use app\common\model\BaseModel;
+use think\model\concern\SoftDelete;
+
+
+/**
+ * 采购订单详情
+ * Class PurchaseOrderInfo
+ * @package app\common\model\purchase_order_info
+ */
+class PurchaseOrderInfo extends BaseModel
+{
+    use SoftDelete;
+    protected $name = 'purchase_order_info';
+    protected $deleteTime = 'delete_time';
+
+    
+}

app/common/model/warehouse/Warehouse.php

@@ -0,0 +1,22 @@
+<?php
+
+namespace app\common\model\warehouse;
+
+
+use app\common\model\BaseModel;
+use think\model\concern\SoftDelete;
+
+
+/**
+ * 仓库信息模型
+ * Class Warehouse
+ * @package app\common\model\warehouse
+ */
+class Warehouse extends BaseModel
+{
+    use SoftDelete;
+    protected $name = 'warehouse';
+    protected $deleteTime = 'delete_time';
+
+    
+}

app/common/model/warehouse_product/WarehouseProduct.php

@@ -0,0 +1,22 @@
+<?php
+
+namespace app\common\model\warehouse_product;
+
+
+use app\common\model\BaseModel;
+use think\model\concern\SoftDelete;
+
+
+/**
+ * 商品仓储信息模型
+ * Class WarehouseProduct
+ * @package app\common\model\warehouse_product
+ */
+class WarehouseProduct extends BaseModel
+{
+    use SoftDelete;
+    protected $name = 'warehouse_product';
+    protected $deleteTime = 'delete_time';
+
+    
+}

app/common/model/warehouse_product_storege/WarehouseProductStorege.php

@@ -0,0 +1,22 @@
+<?php
+
+namespace app\common\model\warehouse_product_storege;
+
+
+use app\common\model\BaseModel;
+use think\model\concern\SoftDelete;
+
+
+/**
+ * 仓库商品存储
+ * Class WarehouseProductStorege
+ * @package app\common\model\warehouse_product_storege
+ */
+class WarehouseProductStorege extends BaseModel
+{
+    use SoftDelete;
+    protected $name = 'warehouse_product_storege';
+    protected $deleteTime = 'delete_time';
+
+    
+}

app/queue/redis/StoreStorageSend.php

@@ -3,12 +3,14 @@
 namespace app\queue\redis;
 
 use app\admin\logic\store_product\StoreProductLogic;
+use app\admin\logic\warehouse_product\WarehouseProductLogic;
 use app\common\model\store_branch_product\StoreBranchProduct;
 use app\common\model\store_branch_product_attr_value\StoreBranchProductAttrValue;
 use app\common\model\store_branch_product_exchange\StoreBranchProductExchange;
 use app\common\model\store_product\StoreProduct;
 use app\common\model\store_product_attr_value\StoreProductAttrValue;
 use app\common\model\system_store_storage\SystemStoreStorage;
+use app\common\model\warehouse_product_storege\WarehouseProductStorege;
 use Webman\RedisQueue\Consumer;
 use support\Log;
 use think\facade\Db;
@@ -31,16 +33,17 @@ class StoreStorageSend implements Consumer
         $store_id = $data['store_id'];
         $stock_type = $data['stock_type'];
         $admin_id = $data['admin_id'];
+        $warehouse_id = $data['warehouse_id']??0;
         $find = StoreProduct::where('id', $product_arr['id'])->findOrEmpty()->toArray();
         if($stock_type == 1){
-            $this->ordinary($product_arr,$store_id,$admin_id,$find);
+            $this->ordinary($product_arr,$store_id,$admin_id,$find,$warehouse_id);
         }elseif($stock_type == 2){
-            $this->exchange($product_arr,$store_id,$admin_id,$find);
+            $this->exchange($product_arr,$store_id,$admin_id,$find,$warehouse_id);
         }
     }
 
     /**普通 */
-    public function ordinary($product_arr,$store_id,$admin_id,$find){
+    public function ordinary($product_arr,$store_id,$admin_id,$find,$warehouse_id){
         $store_find = StoreBranchProduct::where(['product_id' => $product_arr['id'], 'store_id' => $store_id])->findOrEmpty()->toArray();
         if ($find && !$store_find) {
             $attr_value = StoreProductAttrValue::where('product_id', $product_arr['id'])->findOrEmpty();
@@ -82,7 +85,7 @@ class StoreStorageSend implements Consumer
                 ];
                 StoreBranchProductAttrValue::create($arr);
                 if ($product_arr['stock'] > 0) {
-                    $this->storage($find, $store_id, $admin_id, $product_arr);
+                    $this->storage($find, $store_id, $admin_id, $product_arr,$warehouse_id);
                 }
                 StoreProductLogic::updateGoodsclass($find['cate_id'],$store_id);
                 Db::commit();
@@ -96,7 +99,7 @@ class StoreStorageSend implements Consumer
             Db::startTrans();
             try {
                 if ($product_arr['stock'] > 0) {
-                    $this->storage($find, $store_id, $admin_id, $product_arr,1);
+                    $this->storage($find, $store_id, $admin_id, $product_arr,1,$warehouse_id);
                 }
                 Db::commit();
                 return true;
@@ -109,7 +112,7 @@ class StoreStorageSend implements Consumer
     }
 
     /**兑换 */
-    public function exchange($product_arr,$store_id,$admin_id,$find){
+    public function exchange($product_arr,$store_id,$admin_id,$find,$warehouse_id){
         $store_find = StoreBranchProductExchange::where(['product_id' => $product_arr['id'], 'store_id' => $store_id])->findOrEmpty()->toArray();
         if ($find && !$store_find) {
             Db::startTrans();
@@ -133,7 +136,7 @@ class StoreStorageSend implements Consumer
                 ];
                 StoreBranchProductExchange::create($product);
                 if ($product_arr['stock'] > 0) {
-                    $this->storage($find, $store_id, $admin_id, $product_arr);
+                    $this->storage($find, $store_id, $admin_id, $product_arr,$warehouse_id);
                 }
                 // StoreProductLogic::updateGoodsclass($find['cate_id'],$store_id);
                 Db::commit();
@@ -147,7 +150,7 @@ class StoreStorageSend implements Consumer
             Db::startTrans();
             try {
                 if ($product_arr['stock'] > 0) {
-                    $this->storage($find, $store_id, $admin_id, $product_arr,2);
+                    $this->storage($find, $store_id, $admin_id, $product_arr,2,$warehouse_id);
                 }
                 Db::commit();
                 return true;
@@ -158,7 +161,7 @@ class StoreStorageSend implements Consumer
             }
         }
     }
-    public function storage($find, $store_id, $admin_id, $product_arr,$stock_type=1)
+    public function storage($find, $store_id, $admin_id, $product_arr,$stock_type=1,$warehouse_id=0)
     {
         $storage = [
             'product_id' => $product_arr['id'],
@@ -167,13 +170,28 @@ class StoreStorageSend implements Consumer
             'admin_id' => $admin_id,
             'type' => $stock_type,
         ];
-        if ($find['stock'] < $product_arr['stock']) {
+        $data=[
-            $storage['status'] = -1;
+            'warehouse_id'=>$warehouse_id,
-            $storage['mark'] = '库存不足,主库存为:' . $find['stock'];
+            'product_id' => $product_arr['id'],
+            'financial_pm' => 0,
+            'batch' => $product_arr['batch']??1,
+            'nums' => $product_arr['stock'],
+            'status' =>1,
+            'admin_id' =>$admin_id,
+        ];
+        $warehouse=WarehouseProductStorege::where('warehouse_id',$warehouse_id)->where('product_id',$product_arr['id'])->find();
+        if ($warehouse) {
+            if($warehouse['nums']< $product_arr['stock']){
+                $storage['status'] = -1;
+                $data['status'] = -1;
+                $storage['mark'] = '库存不足,分库存为:' .$warehouse['nums'];
+                $data['mark'] = '库存不足,分库存为:' .$warehouse['nums'].' 总仓库存为:'.$find['stock'];
+            }
             SystemStoreStorage::create($storage);
+            WarehouseProductLogic::add($data);
         } else {
             SystemStoreStorage::create($storage);
-            StoreProduct::where('id', $product_arr['id'])->dec('stock', $product_arr['stock'])->update();
+            WarehouseProductLogic::add($data);
         }
     }