phpstock/app/admin/controller/CombindStock.php

<?php
declare (strict_types = 1);

namespace app\admin\controller;

use app\admin\model\CombindBninfo;use app\admin\model\CombindStockInfo;use app\admin\model\GoodCombind;use app\admin\model\GoodStock;use app\admin\model\GoodStockInfo;use think\App;use think\facade\Db;use think\facade\Validate;

class CombindStock extends Base
{
	private  $combind ;
	private  $combindStock ;
	private  $combindStockInfo ;
	private  $combindBninfo;
	public function __construct(App $app) {
		parent::__construct($app);
		$this->combindStock =new \app\admin\model\CombindStock();
		$this->combindStockInfo =new \app\admin\model\CombindStockInfo();
		$this->combindBninfo =new \app\admin\model\CombindBninfo();
		$this->combind =new \app\admin\model\GoodCombind();
	}
 
	public function list(){
		$param=$this->request->only(['spuCode'=>'','wsm_code'=>'','good_name'=>'','cat_id'=>'','status'=>'','flag'=>'',
		"create_start"=>"2023-01-01 00:00:00","create_end"=>date("Y-m-d H:i:s")],'post','trim');
		$where=[["createtime","between",[$param['create_start'],$param['create_end']]]];
		$param['spuCode']?? $where[]=["spuCode","like","%{$param['spuCode']}%"];
		$param['wsm_code']?? $where[]=["wsm_code","like","%{$param['wsm_code']}%"];
		$param['good_name']?? $where[]=["good_name","like","%{$param['good_name']}%"];
		$param['cat_id']?? $where[]=["good_basic.cat_id","=",$param['cat_id']];
		$list = $this->combindStock->withJoin(["wsminfo","good"],"left")->order("id desc")->paginate
		(["page"=>$param['page'],"list_rows"=>$param['size']]);
		return app_show(0,"获取成功",["list"=>$list->items(),"count"=>$list->total()]);
		
	}
	/**@param spuCode 商品编号
	 **@param wsm_code 仓库编号
	 **@param stock_num  库存数量
	 **@param flag  0 减库存 1 加库存
	 * @return \think\response\Json|void
	 */
	public function create(){
		$param =$this->request->only(["spuCode"=>"","wsm_code"=>"","stock_num"=>"",'flag'=>''],"post","trim");
		$valid =Validate::rule([
			"spuCode|商品编号"=>"require",
			"wsm_code|仓库编号"=>"require",
			"stock_num|库存数量"=>"require|number|gt:0",
			"flag|库存变化标识"=>"require|number|in:0,1"]);
		if($valid->check($param)==false)return error_show(1004,$valid->getError());
		$goodbasic =Db::name("good")->where("spuCode",$param["spuCode"])->find();
		if($goodbasic==false) return error_show(1004,"未找到组合商品信息");
		if($goodbasic['is_combind']==0) return error_show(1004,'商品不是组合商品');
		if($param['flag']==0){//减库存 先判断库存是否足够
			if($goodbasic['usable_stock']<$param['stock_num'])return error_show(1004,"商品库存数不足");
			$stock = Db::name("good_stock")->where(["spuCode"=>$param['spuCode'],"wsm_code"=>$param["wsm_code"]])->value("usable_stock",0);
			if($stock< $param['stock_num'])return error_show(1004,'商品库存数不足');
		}
		
		$combindList = $this->combind->where([["spuCode"=>$param["spuCode"],"is_del"=>0]])->select()->toArray();
		if(empty($combindList)) return error_show(1004,"未找到组合商品的商品组合信息");
		$childarr= Db::name('good')->whereIn('spuCode',array_unique(array_column($combindList,'childCode')))->column("spuCode,usable_stock,is_combind","spuCode");
		
		$stockCode=makeNo("CB");
		$this->combindStock->startTrans();
		try{
			$data=[
				"stockCode"=>$stockCode,
				"spuCode"=>$param["spuCode"],
				"wsm_code"=>$param["wsm_code"],
				"good_name"=>$goodbasic['good_name'],
				"flag"=>$param["flag"],
				"stock_num"=>$param['stock_num'],
				"apply_name"=>$this->uname,
				"apply_id"=>$this->uid,
				"status"=>1
			];
			$up =$this->combindStock->save($data);
			if($up==false) throw new \Exception("创建失败");
			if($param["flag"]==0){
				$stockup = Db::name('good')->where('spuCode',$param['spuCode'])->dec('usable_stock',$param["stock_num"])
					->update();
				if($stockup==false) throw new \Exception('组合商品库存占用失败');
			}else{
				foreach ($combindList as $item){
					if(!isset($childarr[$item['childCode']])) throw new \Exception('未找到组合商品的子商品信息');
					$num = bcmul($item['child_num'],$param['stock_num'],2);
					if($childarr[$item['childCode']]['usable_stock']<$num)throw new \Exception($item['childCode'].'组合商品的子商品库存不足');
					
					$stockup = Db::name("good")->where("spuCode",$item["childCode"])->dec("usable_stock",intval($num))
					->update();
					if($stockup==false) throw new \Exception($item["childCode"].'组合商品的子商品信息库存占用失败');
				}
			}
			$this->combindStock->commit();
		}catch (\Exception $exception){
			$this->combindStock->rollback();
			return error_show(1004,$exception->getMessage());
		}
		return app_show(0,"数据创建成功",$stockCode);
	}
	
	
	public function info(){
		$param=$this->request->only(["id"=>""],"post","trim");
		$info =$this->combindStock->withJoin(["good","wsminfo"],"left")->with(['combindgood'])->findOrEmpty($param['id']);
		if($info->isEmpty())return error_show(1004,"未找到数据");
		if(!empty($info->combindgood)){
			foreach ($info->combindgood as &$item){
				$item['stock'] = bcmul($info->stock_num,$item['child_num']);
			}
		}
		return app_show(0,"获取成功",$info);
	}
	
	//status 1 待审核 2审核通过 3 审核驳回
	public  function status(){
		$param=$this->request->only(['id'=>'',"status"=>"","remark"=>""],'post','trim');
		$valid=Validate::rule(["id|主键ID"=>"require","status|状态"=>"require|number|in:2,3"]);
		if($valid->check($param)==false)return error_show(1004,$valid->getError());
		$row = $this->combindStock->findOrEmpty($param['id']);
		if($row->status!=1)return error_show(1004,"数据状态有误");
		$goodinfo = (new \app\admin\model\GoodBasic())->where(['spuCode'=>$row->spuCode])->findOrEmpty();
		if($goodinfo->isEmpty())return error_show(1004,'未找到对应得组合商品信息');
		
		$comblist = (new GoodCombind())->where(["spuCode"=>$row->spuCode,"is_del"=>0])->select()->toArray();
		if(empty($comblist)) return error_show(1004,'组合商品子商品信息未找到');
		
		$row->status = $param['status'];
		$row->remark = $param['remark'];
		$row->startTrans();
		try{
			$up =$row->save();
			if($up==false) throw new \Exception("数据状态更新失败");
			if($param['status']==2){
				$GoodStock =new GoodStock();
				$stock =$GoodStock->where(["spuCode"=>$row->spuCode,"wsm_code"=>$row->wsm_code])->findOrEmpty();
				if($row->flag==1){
					$bn = makeNo('BN');
					if($stock->isEmpty()){
						$wsm_stock = [
							"spuCode"=>$row->spuCode,
							"wsm_code"=>$row->wsm_code,
							"usable_stock"=>$row->stock_num,
							"total_stock"=>$row->stock_num,
							];
						$id =$stock->insertGetId($wsm_stock);
						if($id<=0) throw new \Exception('仓库库存数更新失败');
					}else{
						$wsm_stock=[
							'usable_stock'=>bcadd($stock->usable_stock,$row->stock_num),
							'total_stock'=>bcadd($stock->total_stock,$row->stock_num)
							];
						$up=$stock->save($wsm_stock);
						if($up==false) throw new \Exception("仓库库存数更新失败");
						$id = $stock->id;
					}
					$good= (new \app\admin\model\Good())->where(["spuCode"=>$row->spuCode])->findOrEmpty();
					if($good->isEmpty()==false){
						$good->usable_stock=bcadd($good->usable_stock,$row->stock_num);
						$upe=$good->save();
						if($upe==false)throw new \Exception('商品可用库存数更新失败');
					}
					
					$origin = Db::name('good_nake')->where([['spuCode', '=', $row->spuCode], ['min_num', '<=',
					$row->stock_num], ['is_del', '=', 0]])->order('min_num desc')->find();
		            if ($origin == false) {
		                throw new \Exception( '未找到相关阶梯成本价格');
		            }
		            $origin_price = $origin['nake_total'];
		            $stcoc=GoodStockInfo::AddBn($id,$bn,$row->stock_num,$origin_price);
		            if($stcoc==false)  throw new \Exception( '组合商品bn库存生成失败');
		            $stockCodeLog= (new CombindStockInfo())->save(["stockCode"=>$row->stockCode,"flag"=>1,
		            "stock_num"=>$row->stock_num,"bnCode"=>$bn,"origin_price"=>$origin_price]);
					if($stockCodeLog==false)throw new \Exception( '组合商品bn库存生成失败');
					$bnlist =$this->combind->AddStock($row->spuCode,$row->stock_num);
					(new CombindBninfo())->AaddBNLog($row->spuCode,$bn,$bnlist);
				}else{
					if($stock->usable_stock < $row->stock_num)  throw new \Exception('仓库可用库数不足');
					$up =GoodStockInfo::SaleBn($stock->id,intval($row->stock_num));
			        if(empty($up)) throw new \Exception('未找到对应子商品BN库存信息');
					foreach ($up as $item){
							$bnlist =$this->combind->subStock($row->spuCode,$item['bnCode'],$item['num']);
							if($bnlist==false)throw new \Exception('子商品BN库存信息更新失败');
					}
				}
			}
			if($param['status']==3){
				$good= (new \app\admin\model\Good())->where(['spuCode'=>$row->spuCode])->findOrEmpty();
					if($good->isEmpty()==false){
						if($row->flag==0){
							$good->usable_stock = bcadd($good->usable_stock ,$row->stock_num);
						$stockup = $good->save();
						if($stockup==false) throw new \Exception('组合商品库存解除驳回失败');
						}else{
							foreach ($comblist as $item){
								$num = bcmul($item['child_num'],$row->stock_num);
								$stockup = Db::name('good')->where('spuCode',$item['childCode'])->inc('usable_stock',intval
								($num))->update();
								if($stockup==false) throw new \Exception('组合商品的子商品信息库存占用驳回失败');
							}
						}
					}
			}
			$row->commit();
		}catch (\Exception $exception){
		 $row->rollback();
		 return error_show(1004,$exception->getMessage());
		}
		return app_show(0,"数据更新成功");
	}
}