ddsc/application/purchase/controller/DepotGoods.php

<?php
namespace app\purchase\controller;
use app\common\model\SeckillActivity;
use app\common\model\SeckillGoodsItem;
use app\common\model\StoreGoodsItem;
use app\common\service\PurchaseLogic;
use library\Controller;
use library\tools\Data;
use think\Db;
use function AlibabaCloud\Client\value;

/**
 * 仓库商品
 * Class DepotGoods
 * @package app\purchase\controller
 */
class DepotGoods extends Controller
{

    /**
     * 绑定数据表
     * @var string
     */
    protected $table = 'DepotGoods';

    /**
     * 列表
     * @auth true
     * @menu true
     * @throws \think\Exception
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     * @throws \think\exception\PDOException
     */
    public function index()
    {
        $lid = input('id');
        $search_name = input('search_name','');
        $this->title = '商品盘点' ;Db::name('Depot')->where('id',$lid)->value('name');
        $this->lid = $lid;
        $where = [];
        $where[]= ['v.depot_id','=',$lid];
        if($search_name) $where[] = ['g.name','like',"%".$search_name."%"];
        $list = $this->_query($this->table)->alias('v')
            ->field('v.create_at,v.sort,v.id,v.online_id,v.goods_id,v.depot_id,g.name as goods_name,g.cover,g.name,g.low_price,g.status,g.is_deleted')
            ->where($where)
            ->join('BaseGoods g','v.goods_id = g.id','LEFT')
            ->order('v.sort desc ,v.id desc')
            ->page();
    }


    /**
     * 数据列表处理
     * @auth true
     * @menu true
     * @param array $data
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    protected function _index_page_filter(&$data)
    {
        foreach ($data as &$v){
            $v['list'] = Db::name('DepotGoodsItem')->where('goods_id', $v['id'])->select();
        }

    }



    /**
     * 可添加商品列表
     * @auth true
     * @menu true
     * @param array $data
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function goods_list()
    {
        $lid = input('id');
        $this->title = Db::name('Depot')->where('id',$lid)->value('name');
        $this->lid = $lid;
        $name = input('name');
        $sel_ids = Db::name('DepotGoods')->where(['depot_id'=>$lid])->column('goods_id');
        $where = [];
        $where[]= ['is_deleted','=',0];
        $where[]= ['status','=',1];
        if(!empty($sel_ids)) $where[] = ['id','not in',$sel_ids];
        if($name) $where[] = ['name','like','%'.$name.'%'];
        $list = $this->_query('StoreGoods')
            ->field('id,name,cover,low_price')
            ->where($where)
            ->order('sort desc ,id desc')->page();
        return $this->fetch('goods_list');
    }


    /**
     * ajax添加商品
     * @auth true
     * @menu true
     * @param array $data
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */

    public function ajax_add()
    {
        $sel_goods = input('post.ids');
        $depot_id = input('post.depot_id');
        foreach ($sel_goods as $goods_id){
            $int_data[]=[
                'depot_id' => $depot_id,
                'goods_id' => $goods_id,
                'sort' => 0,
                'create_at' => date("Y-m-d H:i:s")
            ];
            $goods_item = StoreGoodsItem::where('goods_id',$goods_id)->field("goods_id,id as spec_id,goods_spec")->select()->toArray();
            array_walk($goods_item,function (&$v,$k)use($depot_id,$goods_id){
                $v['depot_id'] = $depot_id;
                Data::save('DepotGoodsItem',$v,'depot_id',['depot_id'=>$depot_id,'goods_id'=>$goods_id,'spec_id'=>$v['spec_id']]);
            });
        }
        Db::name('DepotGoods')->insertAll($int_data);
        return json_encode(['code'=>200]);
    }


    /**
     * 商品添加到商城
     * @auth true
     * @menu true
     * @param array $data
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function online()
    {

        if($this->request->isAjax()) {
            $id =  input('post.id');
            PurchaseLogic::deoptGoodsOnline($id);
            $this->success('上架成功');
        }
    }

    /**
     * 商品库存入库
     * @auth true
     * @throws \think\Exception
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     * @throws \think\exception\PDOException
     */
    public function stock()
    {
        if ($this->request->isGet()) {
            $id = $this->request->get('id');
            $depot_goods = Db::name('DepotGoods')->where(['id' => $id])->find();
            $list = Db::name('DepotGoodsItem')->where(['goods_id' => $depot_goods['id'],'depot_id'=>$depot_goods['depot_id']])->select();
            $this->fetch('', ['list' => $list,'depot_id'=>$depot_goods['depot_id'],'goods_id'=>$depot_goods['id']]);
        } else {
            list($post, $data) = [$this->request->post(), []];
            if(!$post['depot_id'] || !$post['goods_id'] ||!$post['order_id']) $this->error('参数错误');
            if($post['type'] == 1) {
                $depot_order = Db::name('SupplierOrder')->where('id',$post['order_id'])->value('id');
                if(!$depot_order)  $this->error('供货订单未录入');
            }else{
                $goods_order = Db::name('GoodsOrder')->where('id',$post['order_id'])->value('id');
                if(!$goods_order)  $this->error('商品订单不存在');
            }

            if (isset($post['spec_id']) && is_array($post['spec_id'])) {
                foreach (array_keys($post['spec_id']) as $key) {
                    if ($post['goods_number'][$key] > 0)
                        array_push($data, [
                        'depot_id'      => $post['depot_id'],
                        'order_id'      => $post['order_id'],
                        'goods_id'      => $post['goods_id'],
                        'spec_id'       => $post['spec_id'][$key],
                        'goods_spec'    => $post['goods_spec'][$key],
                        'num'           => $post['goods_number'][$key],
                        'remark'        => $post['remark'],
                        'type'          => $post['type'],
                    ]);
                }
                if (!empty($data)) {
                    Db::startTrans();
                    Db::name('DepotGoodsInfo')->insertAll($data);// 生成入库记录
                    foreach ($data as $dv) {
                        if($post['type'] == 1){
                            Db::name('DepotGoodsItem')->where(['goods_id'=>$dv['goods_id'],'depot_id'=>$dv['depot_id'],'spec_id'=>$dv['spec_id']])
                                ->update(['stock'=>Db::raw('stock +'.$dv['num']),'base_stock'=>Db::raw('base_stock + '.$dv['num'])]);
                        }else{
                            Db::name('DepotGoodsItem')->where(['goods_id'=>$dv['goods_id'],'depot_id'=>$dv['depot_id'],'spec_id'=>$dv['spec_id']])
                                ->update(['stock'=>Db::raw('stock -'.$dv['num'])]);
                        }
                    }
                    Db::commit();
                    $post['type'] == 1 ?$this->success('商品信息入库成功！') :$this->success('商品信息出库成功！');
                }
            }
            $this->error('没有入库数据！');
        }
    }


    /**
     * 表单数据处理
     * @auth true
     * @menu true
     * @param array $data
     */
    protected function _form_filter(&$data)
    {

    }
    protected function  _form_result($result){

    }

}