project-manager/api/app/common/service/StockService.php

<?php

namespace app\common\service;

use app\common\util\Result;
use think\annotation\route\Group;
use think\facade\Db;
use app\common\model\Good;
use app\common\model\Repo;
use app\common\model\Stock;
use app\common\util\WhereBuilder;
use app\common\util\PhpSpreadsheetExportV2;

class StockService extends Service
{
    public function page($params = [])
    {
        $this->autoParams($params);
        $keyword = $this->pg('keyword');
        $repo_id = $this->pg('repo_id');
        $good_id = $this->pg('good_id');
        $filter_zero_transit = $this->pgd(false, 'filter_zero_transit');
        if ($repo_id && !Repo::find($repo_id)) {
            throw $this->exception('仓库不存在');
        }
        if ($good_id && !Good::find($good_id)) {
            throw $this->exception('物品不存在');
        }

        $where = WhereBuilder::builder()
            ->like('g.no|g.name|r.name', $keyword)
            ->in('s.repo_id', $repo_id)
            ->build();

        $transit_filter_symbol = '>=';
        if ($filter_zero_transit) {
            $transit_filter_symbol = '>';
        }

        $page = (new Stock)
            ->alias('s')
            ->field('s.*, g.name as good_name, g.no as good_no, r.name as repo_name, IFNULL(sum(abs(d.num) - d.transit_received), 0) as sum_transit')
            ->join('good g', 'g.id = s.good_id', 'LEFT')
            ->join('repo r', 'r.id = s.repo_id', 'LEFT')
            ->join('io_detail d', 'd.good_id = s.good_id AND d.repo_id = s.repo_id AND d.transit_status = "TRANSIT"', 'LEFT')
            ->where($where)
            ->whereRaw("IFNULL(abs(d.num) - d.transit_received, 0) $transit_filter_symbol 0")
            ->group('s.id')
            ->paginate($this->tp6Page(PHP_INT_MAX));

        return $page;
    }

    public function allByRepo($params = [])
    {
        $this->autoParams($params);

        $repo = $this->one(Repo::class);

        return (new Stock)->where('repo_id', '=', $repo->id)->select();
    }

    public function info($params = [])
    {
        $this->autoParams($params);

        $stock = $this->one(Stock::class);
        $stock->append(['good']);

        return $stock;
    }

    public function getByGoodAndRepo($params = [])
    {
        $this->autoParams($params);
        $good = $this->one(Good::class, 'good_id');
        $repo = $this->one(Repo::class, 'repo_id');
        return (new Stock)
            ->with(['good'])
            ->where('good_id', '=', $good->id)
            ->where('repo_id', '=', $repo->id)
            ->find()
            ?? Result::rest(['repo_id' => $repo->id, 'good_id' => $good->id, 'num' => 0]);
    }

    /**
     * tp6是支持事务嵌套的，为了保证修改库存时数据不出现问题，请无脑使用该事务方法
     */
    public function chengeStockTrans(Repo $repo, Good $good, $change)
    {
        // tp6是支持事务嵌套的，所有修改可以直接用事务
        return Db::transaction(fn() => $this->changeStock($repo, $good, $change));
    }

    protected function changeStock(Repo $repo, Good $good, $change)
    {
        if (!$repo) {
            throw $this->exception('致命错误，$repo为空');
        }
        if (!$good) {
            throw $this->exception('致命错误，$good为空');
        }
        /**
         * @var Stock
         */
        $stock = (new Stock)
            ->lock(true)
            ->where('good_id', '=', $good->id)
            ->where('repo_id', '=', $repo->id)
            ->find();
        if (!$stock) {
            $stock = Stock::create([
                'repo_id' => $repo->id,
                'good_id' => $good->id,
                'num' => 0
            ]);
        }
        if ($change < 0 && $stock->num < abs($change)) {
            $info = <<<EOF
            物品{$good->name}库存不足，当前库存为{$stock->num}，出库数量为{$change}
            出现这种情况可能有以下原因：
            - 在该操作前，该物品已由另一名操作员出库，导致库存不足
            - 多个相同商品出库相加库存不足
            - 库存不足
            - 库存低于0.01，此时系统会认为没有库存，请避免此类情况的发生
            - 出库数量/库存数量过高导致溢出，如出现此类情况请联系开发人员解决
            EOF;
            throw $this->exception($info);
        }
        $stock->num += $change;
        $stock->save();
    }

    public function export($params = [])
    {
        $params = $this->autoParams($params);
        $params['pageParams']['size'] = PHP_INT_MAX;
        $stocks = $this->page($params)->getCollection();
        $stocks = $stocks->map(fn(Stock $stock) => $stock->getData());
        $header = [
            [
                'id',
                '仓库id',
                '商品id',
                '创建时间',
                '更新时间',
                '删除时间',
                '数量',
                '商品名',
                '编号',
                '仓库名',
                '在途数量'
            ]
        ];
        $res = PhpSpreadsheetExportV2::outputFile(
            $stocks,
            $header,
            '仓储管理系统' . date('Ymdis'),
            []
        );
        return $res;
    }

}