<?php
/**
 * 备库申请
 */

namespace app\admin\controller;

use app\admin\model\ActionLog;
use app\admin\model\DataGroup as DataGroupModel;
use app\admin\model\GoodLog;
use app\admin\model\ProcessOrder;
use think\facade\Cache;
use think\facade\Config;
use think\facade\Db;
use think\App;

//备货
class Resign extends Base
{
    public function __construct(App $app)
    {
        parent::__construct($app);
    }
    public function list(){

        $page = isset($this->post['page']) && $this->post['page'] !=="" ? intval($this->post['page']):"1";
        $size = isset($this->post['size']) && $this->post['size'] !=="" ? intval($this->post['size']):"10";
        $where =[['p.is_del',"=",0]];
        $bkcode = isset($this->post['bk_code']) && $this->post['bk_code']!="" ? trim($this->post['bk_code']):"";
        if($bkcode!=""){
           //$where['p.bk_code'] = $bk_code;
            $where[]=['p.bk_code',"like","%{$bkcode}%"];
        }
        $good_code = isset($this->post['good_code']) && $this->post['good_code']!="" ? trim($this->post['good_code']):"";
        if($good_code!=""){
           // $where['p.good_code'] = $good_code;
            $where[]=['p.spuCode',"like","%{$good_code}%"];
        }

        $good_type_code = isset($this->post['good_type_code']) && $this->post['good_type_code']!="" ? trim($this->post['good_type_code']):"";
        if($good_type_code!=""){
           // $where['p.good_type_code'] = $good_type_code;
            $where[]=['p.good_type_code',"like","%{$good_type_code}%"];
        }
        $wsm_code = isset($this->post['wsm_code']) && $this->post['wsm_code']!="" ? trim($this->post['wsm_code']):"";
        if($wsm_code!=""){
            //$where['p.wsm_code'] = $wsm_code;
            $where[]=['p.wsm_code',"=",$wsm_code];
        }
        $good_name = isset($this->post['good_name']) && $this->post['good_name']!="" ? trim($this->post['good_name']):"";
        if($good_name!=""){
          //  $where['p.good_name'] = Db::raw(" like '%{$good_name}%'");
            $where[]=['p.good_name',"like","%{$good_name}%"];
        }

        $apply_name = isset($this->post['apply_name']) && $this->post['apply_name']!="" ? trim($this->post['apply_name']):"";
        if($apply_name!=""){
          //  $where['p.apply_name'] =Db::Raw("like '%{$apply_name}%'");
            $where[]=['p.apply_name',"like","%{$apply_name}%"];
        }
        $status = isset($this->post['status']) && $this->post['status']!=="" ? intval($this->post['status']):"";
        if($status!==""){
           // $where['p.status'] = $status;
            $where[]=['p.status',"=",$status];
        }

        $start = isset($this->post['start']) && $this->post['start']!=="" ? $this->post['start']:"";
        if($start!==""){
            //$where['p.addtime'] = Db::Raw(">= '{$start}'");
            $where[]=['p.addtime',">=",$start];
        }
        $end = isset($this->post['end']) && $this->post['end']!=="" ? $this->post['end']:"";
        if($end!==""){
           // $where['p.addtime'] = Db::Raw("<= '{$end}'");
            $where[] = ['p.addtime', "<=", $end . ' 23:59:59'];
        }
//        $role=$this->checkRole();
        $condition=[];
//        if(!empty($role['write']) && $this->uid!=""){
//            // $where[]=["a.apply_id","in",$role['write']];
//            $condition .="p.cgderid = {$this->uid} or p.apply_id in (".implode(',',$role['write']).")";
//        }

        //超管、库管、库管-张凯旋、boss能看到所有，其他人只能看到自己创建的和身为采购员的单子
        $super_roleid = array_merge([1, 33], config('app.wsm_cgder_role'));
        if (!in_array($this->roleid, $super_roleid)) {
        	$role = $this->checkDataShare();
        	$hand =resign_hand_user($this->uid,0);
        if (!empty($role[DataGroupModel::$type_全部])){
        	$arr= array_unique(array_merge($hand,$role[DataGroupModel::$type_全部]));
        	$condition[]= ["p.apply_id","in",$arr];
        	$condition[]= ["p.cgderid","in",$hand];
        }
//        	$condition .="p.cgderid in {$hand}  or p.apply_id in {$hand} or p.apply_id in ("
//        .implode(',',$role[DataGroupModel::$type_全部]).")";
        }

        $company_name = isset($this->post['company_name']) && $this->post['company_name'] !== "" ? trim($this->post['company_name']) : "";
        if ($company_name !== "") $where[] = ["p.apply_id", 'in', get_company_item_user_by_name($company_name)];

//        if(!empty($role['platform']) ){
//            $where[]=["p.platform_id","in",$role['platform']];
//        }
        $count=Db::name("purchease")
            ->alias('p')
            ->leftJoin("depart_user u", "u.uid=p.apply_id AND u.is_del=0")
            ->where($where)
            ->where(function ($query)use ($condition){$query->whereOr($condition);})
            ->count();
        $total = ceil($count/$size);
        $page = $page >= $total ? $total : $page;
        $list = Db::name("purchease")
            ->alias('p')
            ->field('p.*,u.itemid')
            ->leftJoin("depart_user u", "u.uid=p.apply_id AND u.is_del=0")
            ->where($where)
            ->where(function ($query)use ($condition){$query->whereOr($condition);})
            ->page($page,$size)
            ->order("p.addtime desc")
            ->cursor();
        $data=[];
        foreach ($list as $value){
            $value['wsm_name']="";
            $value['wsm_supplier']="";
            $value['wsm_supplierNo']="";
            if($value['wsm_code']!=""){
                $wsmcode = Db::name("warehouse_info")->alias("a")->leftJoin("supplier b","a.supplierNo=b.code")
                    ->where(["a.wsm_code"=>$value['wsm_code']])->field("a.name as wsm_name,b.name,b.code")->find();
                $value['wsm_name'] =isset($wsmcode['wsm_name']) ? $wsmcode['wsm_name']:"";
                $value['wsm_supplier'] =isset($wsmcode['name']) ? $wsmcode['name']:"";
                $value['wsm_supplierNo'] =isset($wsmcode['code']) ? $wsmcode['code']:"";
            }
            $value['file_name'] ='';
            if($value['file_url']){
                $file= basename($value['file_url']);
                $value['file_name'] =substr($file,0,strripos($file,"_"));
            }
            $value['company_name'] = implode('/', array_column(GetPart($value['itemid']), 'name'));

            //是否具有编辑权限
//            $value['is_allow_update'] = 0;
//            if (in_array($this->roleid, $super_roleid) || in_array($value['apply_id'], $role[DataGroupModel::$type_可编辑])) $value['is_allow_update'] = 1;

            $data[]=$value;
        }
        return app_show(0,"获取成功",["count"=>$count,"list"=>$data]);
    }

    public  function add(){
        $token = isset($this->post['token']) ? trim($this->post['token']) : "";
        if($token==""){
            return error_show(101,'token不能为空');
        }
        $good_code = isset($this->post['good_code']) && $this->post['good_code']!=""?trim($this->post['good_code']):"";
        if($good_code==""){
            return error_show(1004,"参数good_code不能为空");
        }
        $good_num = isset($this->post['good_num'])&& $this->post['good_num']!==""? intval($this->post['good_num']):"";
        if($good_num===""){
            return error_show(1004,"参数good_code不能为空");
        }
        $file_url = isset($this->post['file_url'])&& $this->post['file_url']!==""? trim($this->post['file_url']):"";
        if($file_url===""){
            return error_show(1004,"参数file_url不能为空");
        }
        $mark =isset($this->post['remark'])&&$this->post['remark']!=""?trim($this->post['remark']):"";
        if($mark==""){
            return error_show(1004,"参数remark不能为空");
        }
        $good =Db::name("good_basic")->where([["spuCode","=",$good_code],["is_del","=",0]])->find();

        if($good==false){
            return error_show(1004,"未找到商品数据");
        }
        $supplier=Db::name("supplier")->where("code","=",$good['supplierNo'])->find();
        if($supplier==false)  return error_show(1004,"未找到供应商数据");
//        $bk= Db::name("purchease")->where([["spuCode","=",$good_code],["status","<>",2],["is_del","=",0]])->find();
//        if($bk!=false) return error_show(1004,"存在未完成备库单数据");
//        $cgd =Db::name("purchease_order")->where([["spuCode","=",$good_code],["status","in",[0,1]],["is_del","=",0]])->find();
//        if($cgd!=false) return error_show(1004,"存在未完成采购单数据");
        //查验仓库库存数量
//        $stock =Db::name("good_stock")->alias("a")->leftJoin("warehouse_info b","a.wsm_code=b.wsm_code")->where
//        (["spuCode"=>$good_code, "a.is_del"=>0,"a.status"=>1,"b.companyNo"=>$good['companyNo']])->field("a.id,a.usable_stock,a.wait_out_stock")->find();
//        if(isset($stock['usable_stock'])&& $stock['usable_stock']!=0){
//            return error_show(1003,"库存数量为 {$stock['usable_stock']} 无法备库");
//        }
        //校验数量
        $goodnake = Db::name("good_nake")
            ->field('id,min_num')
            ->where([["spuCode", "=", $good_code], ["is_del", "=", 0]])
            ->order("min_num asc")
            ->find();

        if (empty($goodnake)) return error_show(1004, '未找到商品成本数据');
        $minnum = $goodnake['min_num'];
        if($good['is_stock']==1 && $good['stock_moq']>0){
            $minnum =$good['stock_moq'];
        }
        if ($minnum > $good_num) return error_show(1004, '该商品最低采购数量为' . $minnum);


        $lastime = isset($this->post['lastime'])&&$this->post['lastime']!="" ? $this->post['lastime']:"";
        if($lastime===""){
            return error_show(1004,"参数lastime不能为空");
        }
//        $data = GetUserInfo($token);
//        if((!empty($data) && $data['code']!=0) ||empty($data) ){
//            return error_show($data['code'],$data['message']);
//        }
//        $userinfo = $data['data'];
        $bk_code=makeNo("BK");
        $info = [
            "spuCode"=>$good['spuCode'],
            "good_name"=>$good['good_name'],
            "good_num"=>$good_num,
            "wsm_code"=>'',
            "companyNo"=>$good['companyNo'],
            "supplierNo"=>$good['supplierNo'],
            "file_url"=>$file_url,
            "lasttime"=>$lastime,
            "status"=>1,
            "remark"=>$mark,
            "cgder" => $good['charger'],//$good['creater'],
            "cgderid" => $good['chargerid'],//$good['createrid'],
            "addtime"=>date("Y-m-d H:i:s"),
            "updatetime"=>date("Y-m-d H:i:s"),
            "apply_id"=>$this->uid,
            "apply_name"=>$this->uname,
            "bk_code"=>$bk_code
        ];
        $in = Db::name("purchease")->insert($info,true);
        if($in>0){
            //备库单，推给供应商负责人
            $order = ["order_type" => 'BHD', "order_code" => $bk_code, "order_id" => $in, "order_status" => 1, "before_status" => 1, 'wait_id' => $supplier['personid'], 'wait_name' => $supplier['person']];
            ProcessOrder::AddProcess(['id' => $this->uid, 'nickname' => $this->uname], $order);
            $ste = ["order_code" => $bk_code, "status" => 0, "action_remark" => '', "action_type" => "create"];
            ActionLog::logAdd(['id' => $this->uid, 'nickname' => $this->uname], $ste, "BHD", 1, $info);

            //台账记录
            Db::name('standing_book')
                ->insert([
                    'standBookNo' => makeNo("IO"),
                    'bk_code' => $bk_code,
                    'purchease_id' => $in,
                    'addtime' => date('Y-m-d H:i:s'),
                    'updatetime' => date('Y-m-d H:i:s')
                ]);
          return app_show(0,"新建成功",['bk_code'=>$bk_code]);
        }else{
          return error_show(1005,"新建失败");
        }
    }

    /**
     * @return \think\response\Json|void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public  function  copy(){
        $id = isset($this->post['id']) ? intval($this->post['id']) : "";
        if($id==""){
            return error_show(1001,'id不能为空');
        }
        $info = Db::name("purchease")->where(["id"=>$id,"is_del"=>0])->find();
        if(empty($info)){
            return error_show(1002,'未找到数据');
        }
//        $data = GetUserInfo($this->post['token']);
//        if((!empty($data) && $data['code']!=0) ||empty($data) ){
//            return error_show($data['code'],$data['message']);
//        }
        //查验仓库库存数量
//        $stock =Db::name("good_stock")->alias("a")->leftJoin("warehouse_info b","a.wsm_code=b.wsm_code")->where
//        (["spuCode"=>$info['spuCode'], "a.is_del"=>0,"a.status"=>1,"b.companyNo"=>$info['companyNo']])->field("a.id,a.usable_stock,a.wait_out_stock")->find();
//        if(isset($stock['usable_stock'])&& $stock['usable_stock']!=0){
//            return error_show(1003,"库存数量为 {$stock['usable_stock']} 无法备库");
//        }
//        $userinfo = $data['data'];
        $bk_code=makeNo("BK");
        $info['bk_code']=$bk_code;
        $info['status']=1;
        $info['addtime']=date("Y-m-d H:i:s");
        $info['updatetime']=date("Y-m-d H:i:s");
        $info['apply_id']=$this->uid;
        $info['apply_name']=$this->uname;
        unset($info['id']);
        $in = Db::name("purchease")->insert($info,true);
        if($in>0){
            $supplier = Db::name('supplier')
                ->field('id,person,personid')
                ->where('code', $info['supplierNo'])
                ->findOrEmpty();
            $order = ["order_type" => 'BHD', "order_code" => $bk_code, "order_id" => $in, "order_status" => 1, "before_status" => 1, 'wait_id' => $supplier['personid'], 'wait_name' => $supplier['person']];
            ProcessOrder::AddProcess(['id' => $this->uid, 'nickname' => $this->uname], $order);
            $ste = ["order_code"=>$bk_code,"status"=>0,"action_remark"=>'',"action_type"=>"create"];
            ActionLog::logAdd(['id' => $this->uid, 'nickname' => $this->uname],$ste,"BHD",1,$info);
            return app_show(0,"新建成功",['bk_code'=>$bk_code]);
        }else{
            return error_show(1005,"新建失败");
        }
    }
    /**
     * @return \think\response\Json|void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function info(){
        $id = isset($this->post['id']) ? intval($this->post['id']) : "";
        if($id==""){
            return error_show(1001,'id不能为空');
        }
        $info = Db::name("purchease")->where(["id"=>$id,"is_del"=>0])->find();
        if(empty($info)){
            return error_show(1002,'未找到数据');
        }
        $good =Db::name("good_basic")->where([["spuCode","=", $info['spuCode']],["is_del","=",0]])->find();
        if($good==false){
            return error_show(1004,"未找到商品数据");
        }
        $int= isset($good['cat_id']) && $good['cat_id'] !=0 ? made($good['cat_id']):[];
        $metal = \think\facade\Config::get("noble");
        $info['noble_metal']= isset($metal[$good['noble_metal']]) && $good['noble_metal'] !=''?$metal[$good['noble_metal']]:'';
        $info['noble_id']= isset($good['noble_metal']) && $good['noble_metal'] !='' ? $good['noble_metal']:"";
        $info['wsm_name']="";
        $info['file_name'] ='';
        if($info['file_url']){
            $file= basename($info['file_url']);
            $info['file_name'] =substr($file,0,strripos($file,"_"));
        }

        if($info['wsm_code']!=""){
            $wsmcode = Db::name("warehouse_info")->alias("a")->leftJoin("supplier b","a.supplierNo=b.code")
                ->where(["a.wsm_code"=>$info['wsm_code']])->field("a.name as wsm_name,b.name,b.code")->find();
            $info['wsm_name'] =isset($wsmcode['wsm_name']) ? $wsmcode['wsm_name']:"";
            $info['wsm_supplier'] =isset($wsmcode['name']) ? $wsmcode['name']:"";
            $info['wsm_supplierNo'] =isset($wsmcode['code']) ? $wsmcode['code']:"";
        }
        $supplier =Db::name("supplier")->where(["code"=>$info['supplierNo']])->find();
        $info['supplier_name'] = isset($supplier['name'])?$supplier['name']:"";
        $company =Db::name("business")->where(["companyNo"=>$info['companyNo']])->find();
        $info['company_name'] = isset($company['company'])?$company['company']:"";
        $info['can']=$int;
        return app_show(0,"获取成功",$info);
    }
    public  function edit(){
        $token = isset($this->post['token']) ? trim($this->post['token']) : "";
        if($token==""){
            return error_show(101,'token不能为空');
        }
        $id = isset($this->post['id']) ? intval($this->post['id']) : "";
        if($id==""){
            return error_show(1001,'id不能为空');
        }
        $info = Db::name("purchease")->where(["id"=>$id,"is_del"=>0])->find();
        if(empty($info)){
            return error_show(1002,'未找到数据');
        }
        $customer = isset($this->post['customer_code'])&&$this->post['customer_code']!="" ?trim($this->post['customer_code']):"";
        if($customer==""){
            return error_show(1004,"参数customer_code不能为空");
        }
        $supplier = isset($this->post['supplier_code'])&&$this->post['supplier_code']!="" ?trim($this->post['supplier_code']):"";
        if($supplier==""){
            return error_show(1004,"参数supplier_code不能为空");
        }
        $good_code = isset($this->post['good_code']) && $this->post['good_code']!=""?trim($this->post['good_code']):"";
        if($good_code==""){
            return error_show(1004,"参数good_code不能为空");
        }
        $good_num = isset($this->post['good_num'])&& $this->post['good_num']!==""? intval($this->post['good_num']):"";
        if($good_num===""){
            return error_show(1004,"参数good_code不能为空");
        }
        $file_url = isset($this->post['file_url'])&& $this->post['file_url']!==""? trim($this->post['file_url']):"";
        if($file_url===""){
            return error_show(1004,"参数file_url不能为空");
        }
        $mark =isset($this->post['remark'])&&$this->post['remark']!=""?trim($this->post['remark']):"";
        if($mark==""){
            return error_show(1004,"参数remark不能为空");
        }
        $good =Db::name("good_basic")->where([["spuCode","=", $good_code],["is_del","=",0]])->find();
        if($good==false){
            return error_show(1004,"未找到商品数据");
        }
//        $data = GetUserInfo($token);
//        if((!empty($data) && $data['code']!=0) ||empty($data) ){
//            return error_show($data['code'],$data['message']);
//        }
//        $userinfo = $data['data'];
        $up =  [
            "spuCode"=>$good_code,
            "good_name"=>$good['good_name'],
            "good_num"=>$good_num,
           // "skuCode"=>$good['skuCode'],
            "companyNo"=>$customer,
            "supplierNo"=>$supplier,
            "file_url"=>$file_url,
            "remark"=>$mark,
            "updatetime"=>date("Y-m-d H:i:s"),
        ];
        $in = Db::name("purchease")->where($info)->save($up);
        if($in){
            $order=["order_type"=>'BHD',"order_code"=>$info['bk_code'],"order_id"=>$info['id'],"order_status"=>$info['status'],"before_status"=>1, 'holder_id' => $info['apply_id']];
            ProcessOrder::AddProcess($this->post['token'],$order);
            $ste = ["order_code"=>$info['bk_code'],"status"=>$info['status'],"action_remark"=>'',"action_type"=>"edit"];
            ActionLog::logAdd($this->post['token'],$ste,"BHD",$info['status'],$up);
            return app_show(0,"更新成功",['bk_code'=>$info['bk_code']]);
        }else{
            return error_show(1005,"更新失败");
        }
    }

    public function delete(){
        $id = isset($this->post['id']) ? intval($this->post['id']) : "";
        if($id==""){
            return error_show(1001,'id不能为空');
        }
        $info = Db::name("purchease")->where(["id"=>$id,"is_del"=>0])->find();
        if(empty($info)){
            return error_show(1002,'未找到数据');
        }
        $info['is_del']=1;
        $info['updatetime']=date("Y-m-d H:i:s");
        $up = Db::name("purchease")->update($info);
        if($up){
            $order=["order_type"=>'BHD',"order_code"=>$info['bk_code'],"order_id"=>$info['id'],"order_status"=>$info['status']];
            ProcessOrder::workdel($order);
            $ste = ["order_code"=>$info['bk_code'],"status"=>$info['status'],"action_remark"=>'',"action_type"=>"delete"];
            ActionLog::logAdd($this->post['token'],$ste,"BHD",$info['status'],$info);
        }
        return $up ? app_show(0,"删除成功"):error_show(1005,"删除失败");
    }

    public function status(){
        $id = isset($this->post['id']) ? intval($this->post['id']) : "";
        if($id==""){
            return error_show(1001,'id不能为空');
        }
        $info = Db::name("purchease")->where(["id"=>$id,"is_del"=>0])->find();
        if(empty($info)){
            return error_show(1002,'未找到数据');
        }
        $status = isset($this->post['status'])&&$this->post['status']!=='' ? intval($this->post['status']) : "";
        if($status===""){
            return error_show(1001,'status不能为空');
        }
        $temp = $info['status'];
        $info['status']= $status;
        $info['updatetime']=date("Y-m-d H:i:s");
        $up = Db::name("purchease")->update($info);
        if($up){

            if($status==1){
                $supplier = Db::name('supplier')
                    ->field('id,person,personid')
                    ->where('code', $info['supplierNo'])
                    ->findOrEmpty();
                $order = ["order_type" => 'BHD', "order_code" => $info['bk_code'], "order_id" => $info['id'], "order_status" => $status, "before_status" => $temp,'wait_id' => $supplier['personid'], 'wait_name' => $supplier['person']];
            }else $order = ["order_type" => 'BHD', "order_code" => $info['bk_code'], "order_id" => $info['id'], "order_status" => $status, "before_status" => $temp, 'holder_id' => $info['apply_id']];
            $order = ["order_type" => 'BHD', "order_code" => $info['bk_code'], "order_id" => $info['id'], "order_status" => $status, "before_status" => $temp, 'holder_id' => $info['apply_id']];
            ProcessOrder::AddProcess($this->post['token'],$order);

            $ste = ["order_code"=>$info['bk_code'],"status"=> $temp,"action_remark"=>'',"action_type"=>"status"];
            ActionLog::logAdd($this->post['token'],$ste,"BHD",$status,$info);
            return app_show(0,"更新成功",['bk_code'=>$info['bk_code']]);
        }else{
            return error_show(1005,"更新失败");
        }
    }


    public  function addFeed(){
        $token = isset($this->post['token']) ? trim($this->post['token']) : "";
        if($token==""){
            return error_show(101,'token不能为空');
        }
        $id = isset($this->post['id']) ? intval($this->post['id']) : "";
        if($id==""){
            return error_show(1001,'id不能为空');
        }
        $info = Db::name("purchease")->where(["id"=>$id,"is_del"=>0])->find();
        if(empty($info)){
            return error_show(1002,'未找到备库数据');
        }
        if($info['status']!=1){
            return error_show(1002,'备库数据状态有误');
        }
        $num = isset($this->post['num']) && $this->post['num']!=="" ? intval($this->post['num']):"";
        if($num==''){
            return error_show(1002,'参数num 不能为空或零');
        }
        $expecttime = isset($this->post['expecttime'])&&$this->post['expecttime']!=''?$this->post['expecttime'] :"";
        if($expecttime==''){
            return error_show(1002,'参数expecttime 不能为空');
        }
        $wsm_type = isset($this->post['wsm_type'])&&$this->post['wsm_type']!="" ? intval($this->post['wsm_type']):"";
        if($wsm_type==""){
            return error_show(1002,'参数wsm_type 不能为空');
        }
        $wsm_code = isset($this->post['wsm_code'])&&$this->post['wsm_code']!="" ? trim($this->post['wsm_code']):"";
        if($wsm_code==""){
            return error_show(1002,'参数wsm_code 不能为空');
        }
        $wsminfo = Db::name("warehouse_info")->where(['wsm_code'=>$wsm_code,"wsm_type"=>$wsm_type,"is_del"=>0])->find();
        if(empty($wsminfo)){
            return error_show(1002,'未找到仓库数据');
        }
        $supplierNo = isset($this->post['supplierNo'])&&$this->post['supplierNo']!="" ? trim($this->post['supplierNo']):"";
        if($supplierNo==""){
            return error_show(1002,'参数supplierNo 不能为空');
        }
        $supplie = Db::name("supplier")->where(['code'=>$supplierNo,"is_del"=>0])->find();
        if(empty($supplie)){
            return error_show(1002,'未找到供应商');
        }
        $good_price = isset($this->post['good_price'])&&$this->post['good_price']!=="" ? $this->post['good_price']:"";
        if($good_price===""){
            return error_show(1002,'参数good_price 不能为空');
        }
       $pakge_fee = isset($this->post['pakge_fee'])&&$this->post['pakge_fee']!=="" ? $this->post['pakge_fee']:0;
       $cert_fee = isset($this->post['cert_fee'])&&$this->post['cert_fee']!=="" ? $this->post['cert_fee']:0;
       $open_fee = isset($this->post['open_fee'])&&$this->post['open_fee']!=="" ? $this->post['open_fee']:0;
       $delivery_fee = isset($this->post['delivery_fee'])&&$this->post['delivery_fee']!=="" ? $this->post['delivery_fee']:0;
       $mark_fee = isset($this->post['mark_fee'])&&$this->post['mark_fee']!=="" ? $this->post['mark_fee']:0;
       $teach_fee = isset($this->post['teach_fee'])&&$this->post['teach_fee']!=="" ? $this->post['teach_fee']:0;
       $nake_fee = isset($this->post['nake_fee'])&&$this->post['nake_fee']!=="" ? $this->post['nake_fee']:0;
       $demo_fee = isset($this->post['demo_fee'])&&$this->post['demo_fee']!=="" ? $this->post['demo_fee']:0;
       $weight = isset($this->post['weight'])&&$this->post['weight']!=="" ? $this->post['weight']:0;
       $diff_weight =isset($this->post['diff_weight'])&&$this->post['diff_weight']!=="" ? $this->post['diff_weight']:0;
       $diff_price =isset($this->post['diff_price'])&&$this->post['diff_price']!=="" ? $this->post['diff_price']:0;
       $remark =isset($this->post['remark'])&&$this->post['remark']!=="" ? $this->post['remark']:'';
        $data = GetUserInfo($token);
        if((!empty($data) && $data['code']!=0) ||empty($data) ){
            return error_show($data['code'],$data['message']);
        }
        $userinfo = $data['data'];
        $data=[
            "bkcode"=>$info['bk_code'],
            "warehouse"=>$wsm_code,
            "wsm_type"=>$wsm_type,
            "num"=>$num,
            'expecttime'=>$expecttime,
            'supplier'=>isset($supplie) && $supplie['code']!=''? $supplie['code']:'',
            'good_price'=>$good_price,
            'pakge_fee'=>$pakge_fee,
            'cert_fee'=>$cert_fee,
            'open_fee'=>$open_fee,
            'mark_fee'=>$mark_fee,
            'teach_fee'=>$teach_fee,
            'nake_fee'=>$nake_fee,
            'demo_fee'=>$demo_fee,
            'delivery_fee'=>$delivery_fee,
            'weight'=>$weight,
            'remark'=>$remark,
            'diff_weight'=>$diff_weight,
            'diff_price'=>$diff_price,
            'purchaser'=>$userinfo['nickname'],
            'purchaser_id'=>$userinfo['id'],
            "addtime"=>date("Y-m-d H:i:s"),
            "updatetime"=>date("Y-m-d H:i:s")
        ];
        Db::startTrans();
        try{
            $in = Db::name('purchease_feedback')->insert($data,true);
            if($in>0){
                $order=["order_type"=>'FKD',"order_code"=>$info['bk_code'],"order_id"=>$in, "order_status"=>0,"before_status"=>1];
                ProcessOrder::AddProcess($this->post['token'],$order);
                $ste = ["order_code"=>$info['bk_code'],"status"=>0,"action_remark"=>'',"action_type"=>"create"];
                ActionLog::logAdd($this->post['token'],$ste,"FKD",0,$data);
                $temp=$info['status'];
                $info['status']=2;
                $info['wsm_code']=$wsm_code;
                $info['addtime']=date("Y-m-d H:i:s");
                $ood=Db::name('purchease')->save($info);
                if($ood){
                    $order=["order_type"=>'BHD',"order_code"=>$info['bk_code'],"order_id"=>$info['id'], "order_status"=>$info['status'],"before_status"=>$temp, 'holder_id' => $info['apply_id']];
                    ProcessOrder::AddProcess($this->post['token'],$order);
                    $ste = ["order_code"=>$info['bk_code'],"status"=>$temp,"action_remark"=>'',"action_type"=>"status"];
                    ActionLog::logAdd($this->post['token'],$ste,"BHD",$info['status'],$info);
                    Db::commit();
                    return app_show(0,"新建成功");
                }
            }
            Db::rollback();
            return error_show(1005,"新建失败");
        }catch (\Exception $e){
            Db::rollback();
            return error_show(1005,"新建失败");
        }

       // return $in ? app_show(0,"新建成功"):error_show(1005,"新建失败");
    }

    public function delFeed(){
        $id = isset($this->post['id']) ? intval($this->post['id']) : "";
        if($id==""){
            return error_show(1001,'id不能为空');
        }
        $feed = Db::name("purchease_feedback")->where(['id'=>$id,'is_del'=>0])->find();
        if(empty($feed)){
            return error_show(1004,'未找到数据');
        }
        if($feed['status']==1){
            return error_show(1004,'反馈数据已采用无法删除');
        }
        $feed['is_del']= 1;
        $feed['updatetime']=date("Y-m-d H:i:s");
        $up = Db::name("purchease_feedback")->update($feed);
        if($up){
            $order=["order_type"=>'FKD',"order_code"=>$feed['bk_code'],"order_id"=>$feed['id'], "order_status"=>0];
            ProcessOrder::workdel($order);
            $ste = ["order_code"=>$feed['bk_code'],"status"=>$feed['status'],"action_remark"=>'',"action_type"=>"delete"];
            ActionLog::logAdd($this->post['token'],$ste,"FKD",$feed['status'],$feed);
        }
        return $up ? app_show(0,"删除成功"):error_show(1005,"删除失败");
    }

    public function infoFeed(){
        $id = isset($this->post['id']) ? intval($this->post['id']) : "";
        if($id==""){
            return error_show(1001,'id不能为空');
        }
        $info = Db::name("purchease")->where(["id"=>$id,"is_del"=>0])->find();
        if(empty($info)){
            return error_show(1002,'未找到备库数据');
        }
        $feed = Db::name("purchease_feedback")->where(['bkcode'=>$info['bk_code'],'is_del'=>0])->find();
        if(empty($feed)){
            return error_show(1004,'未找到反馈数据');
        }
        $feed['wsm_name']="";
        if($feed['warehouse']!=""){
            $wsmcode = Db::name("warehouse_info")->alias("a")->leftJoin("supplier b","a.supplierNo=b.code")
                ->where(["a.wsm_code"=>$feed['warehouse']])->field("a.name as wsm_name,b.name,b.code")->find();
            $feed['wsm_name'] =isset($wsmcode['wsm_name']) ? $wsmcode['wsm_name']:"";
            $feed['wsm_supplier'] =isset($wsmcode['name']) ? $wsmcode['name']:"";
            $feed['wsm_supplierNo'] =isset($wsmcode['code']) ? $wsmcode['code']:"";
        }
        if($feed['supplier']!=""){
            $supplie = Db::name("supplier")->where(['code'=>$feed['supplier'],"is_del"=>0])->find();
            $feed['supplier_name'] =isset($supplie['name']) ? $supplie['name']:"";
        }
        return app_show(0,"获取成功",$feed);
    }

    public function changeFeed(){
        $id = isset($this->post['id']) ? intval($this->post['id']) : "";
        if($id==""){
            return error_show(1001,'id不能为空');
        }
        $feed = Db::name("purchease")->where(['id'=>$id,'is_del'=>0])->find();
        if(empty($feed)){
            return error_show(1004,'未找到数据');
        }
        $status = isset($this->post['status'])&& $this->post['status']!=='' ? intval($this->post['status']) : "";
        if($status==""){
            return error_show(1001,'参数status 不能为空');
        }
        $remark = isset($this->post['remark'])&& $this->post['remark']!=='' ? trim($this->post['remark']) : "";
        Db::startTrans();
        try{
            $tem =$feed['status'];
            $feed['remark']= $remark;
            $feed['status']= $status;
            $feed['updatetime']=date("Y-m-d H:i:s");
            $up = Db::name("purchease")->update($feed);
            if($up){
                if ($feed['status'] == 1) {
                    $supplier = Db::name('supplier')
                        ->field('id,person,personid')
                        ->where('code', $feed['supplierNo'])
                        ->findOrEmpty();
                    $order = ["order_type" => 'BHD', "order_code" => $feed['bk_code'], "order_id" => $feed['id'], "order_status" => $feed['status'], "before_status" => $tem, 'holder_id' => $feed['apply_id'], 'wait_id' => $supplier['personid'], 'wait_name' => $supplier['person']];
                } else $order = ["order_type" => 'BHD', "order_code" => $feed['bk_code'], "order_id" => $feed['id'], "order_status" => $feed['status'], "before_status" => $tem, 'holder_id' => $feed['apply_id']];
                ProcessOrder::AddProcess($this->post['token'], $order);
                $ste = ["order_code"=>$feed['bk_code'],"status"=>$tem,"action_remark"=>'',"action_type"=>"edit"];
                ActionLog::logAdd($this->post['token'],$ste,"BHD",$feed['status'],$feed);
                if($status==3){
                  //  $ware = Db::name("warehouse_addr")->where(["wsm_code"=>$feed['warehouse'],"is_del"=>0])->find();
                    $purse = Db::name("purchease_feedback")->where(['bkcode'=>$feed['bk_code'],"is_del"=>0])->find();
                    if(empty($purse)){
                        Db::rollback();
                        return error_show(1001,'未找到备库反馈数据');
                    }
                    $pe = $purse['status'];
                    $purse['status']=1;
                    $purse['addtime']=date("Y-m-d H:i:s");
                    $up = Db::name("purchease_feedback")->save($purse);
                    if($up==false){
                        Db::rollback();
                        return error_show(1001,'备库反馈数据状态修改失败');
                    }
                    $order=["order_type"=>'FKD',"order_code"=>$feed['bk_code'],"order_id"=>$purse['id'],"order_status"=>$purse['status'],"before_status"=>$pe];
                    ProcessOrder::AddProcess($this->post['token'],$order);
                    $ste = ["order_code"=>$feed['bk_code'],"status"=>$pe,"action_remark"=>'',"action_type"=>"status"];
                    ActionLog::logAdd($this->post['token'],$ste,"FKD",$feed['status'],$purse);
                    $supplier = Db::name("supplier")->where(["code"=>$purse['supplier']])->find();
                    $inw = makeNo("CG");
                    $goodinfo=Db::name('good_basic')
                        ->field('id,createrid,creater')
                        ->where(['is_del'=>0,'spuCode'=>$feed['spuCode']])
                        ->findOrEmpty();
                    $data=[
                        "bkcode"=>$purse['bkcode'],
                        'cgdNo'=>$inw,
                        "wsm_code"=>$purse['warehouse'],
                        "good_code"=>$feed['good_code'],
                        "good_name"=>$feed['good_name'],
                        "good_type_code"=>$feed['good_type_code'],
                        "good_num"=>$feed['good_num'],
                        "send_num"=>0,
                        "wsend_num"=>$feed['good_num'],
                        'good_price'=>$purse['good_price'],
                        "total_fee"=>$purse['good_price'],
                        'pakge_fee'=>$purse['pakge_fee'],
                        'cert_fee'=>$purse['cert_fee'],
                        'open_fee'=>$purse['open_fee'],
                        'mark_fee'=>$purse['mark_fee'],
                        'teach_fee'=>$purse['teach_fee'],
                        'nake_fee'=>$purse['nake_fee'],
                        'demo_fee'=>$purse['demo_fee'],
                        'delivery_fee'=>$purse['delivery_fee'],
                        'weight'=>$purse['weight'],
                        'diff_weight'=>$purse['diff_weight'],
                        'diff_fee'=>$purse['diff_price'],
                        'cgder_id'=>$purse['purchaser_id'],
                        'cgder'=>$purse['purchaser'],
                        "remark"=>$purse['remark'],
                        "status"=>0,
                        'supplierNo'=>$purse['supplier'],
                        'supplier_name'=>isset($supplier['name']) ? $supplier['name']:"",
                        'lasttime'=>$purse['expecttime'],
                        "addtime"=>date("Y-m-d H:i:s"),
                        "updatetime"=>date("Y-m-d H:i:s"),
                        'good_createrid' => $goodinfo['createrid'],
                        'good_creater' => $goodinfo['creater'],//商品的创建人
                    ];
                    $in= Db::name("purchease_order")->insert($data,true);
                    if($in>0){
                        //当采购单是节点0待与供应商确认，推给供应商负责人
                        if(!isset($supplier)) $supplier = Db::name("supplier")->where(["code"=>$purse['supplier']])->find();
                        $order=["order_type"=>'CGD',"order_code"=>$data['cgdNo'],"order_id"=>$in, "order_status"=>$data['status'],"before_status"=>0,'wait_id'=>$supplier['personid'],'wait_name'=>$supplier['person']];
                        ProcessOrder::AddProcess($this->post['token'],$order);
                        $ste = ["order_code"=>$inw,"status"=>$data['status'],"action_remark"=>'',"action_type"=>"create"];
                        ActionLog::logAdd($this->post['token'],$ste,"CGD",$data['status'],$data);

                        //将采购单数据塞入到队列中
                        $push_data = json_encode([
                            'supplierNo' => $data['supplierNo'],
                            'type' => 1,//1销售订单(采销的采购单),2上线结果
                            'data' => [
                                'cgdNo' => $data['cgdNo'],
                                'spuCode' => $feed['spuCode'],
                                'good_name' => $data['good_name'],
                                'good_num' => $data['good_num'],
                                'good_price' => $data['good_price'],
                                'total_fee' => $data['total_fee'],
                                'weight' => $data['weight'],
                                'addtime' => $data['addtime'],
                            ],
                        ], JSON_UNESCAPED_UNICODE);
//                        Cache::store("redis")->handler()->lPush(Config::get('app.abutment_queue'), $push_data);

                        Db::commit();
                        return app_show(0,"更新成功",['cgdNo'=>$inw]);
                    }
                }else{
                    if($status==4){
                        $purse = Db::name("purchease_feedback")->where(['bkcode'=>$feed['bk_code'],"is_del"=>0])->find();
                        if(empty($purse)){
                            Db::rollback();
                            return error_show(1001,'未找到备库反馈数据');
                        }
                        $pe=$purse['status'];
                        $purse['status']=2;
                        $purse['addtime']=date("Y-m-d H:i:s");
                        $up = Db::name("purchease_feedback")->save($purse);
                        if($up==false){
                            Db::rollback();
                            return error_show(1001,'备库反馈数据状态修改失败');
                        }
                        $order=["order_type"=>'FKD',"order_code"=>$feed['bk_code'],"order_id"=>$purse['id'],"order_status"=>$purse['status'],"before_status"=>1];
                        ProcessOrder::AddProcess($this->post['token'],$order);
                        $ste = ["order_code"=>$feed['bk_code'],"status"=>$pe,"action_remark"=>'',"action_type"=>"status"];
                        ActionLog::logAdd($this->post['token'],$ste,"FKD",$feed['status'],$purse);
                    }
                    Db::commit();
                    return app_show(0,"更新成功");
                }
            }
            Db::rollback();
            return error_show(1004,"更新失败");
        }catch (\Exception $e){
            Db::rollback();
            return error_show(1005,$e->getMessage());
        }
    }


    public function addwsm(){
        $id = isset($this->post['id']) ? intval($this->post['id']) : "";
        if($id==""){
            return error_show(1001,'id不能为空');
        }
        $info = Db::name("purchease")->where(["id"=>$id,"is_del"=>0])->find();
        if($info==false){
            return error_show(1002,'未找到备库数据');
        }
        $wsm= isset($this->post['wsm_code'])&&$this->post['wsm_code']!="" ? trim($this->post['wsm_code']) : "";
        if($wsm==""){
            return error_show(1004,"参数wsm_code不能为空");
        }
        $wsminfo = Db::name("warehouse_info")->where(["wsm_code"=>$wsm,"is_del"=>0])->find();
        if($wsminfo==false){
            return error_show(1004,"未找到仓库数据");
        }
        $info['wsm_code']=$wsm;
        $old_info_status = $info['status'];
        $info['status']=1;
        $info['updatetime']=date("y-m-d H;i:s");
        $up =Db::name("purchease")->save($info);
        if($up){

            //修改状态，添加待办
            ActionLog::logAdd($this->post['token'], [
                "order_code" => $info['bk_code'],//销售单code
                "status" => $old_info_status,//这里的status是之前的值
                "action_remark" => '',//备注
                "action_type" => "edit"//新建create，编辑edit，更改状态status
            ], "BHD", $info['status'], $info);

            $supplier = Db::name('supplier')
                ->field('id,person,personid')
                ->where('code', $info['supplierNo'])
                ->findOrEmpty();
            ProcessOrder::AddProcess($this->post['token'], [
                "order_type" => 'BHD',
                "order_code" => $info['bk_code'],//销售单code
                "order_id" => $info['id'],
                "order_status" => $info['status'],
                "before_status"=>$old_info_status,
                //'holder_id' => $info['apply_id'],
                'wait_id' => $supplier['personid'],
                'wait_name' => $supplier['person'],
            ]);

            return app_show(0,"备库单仓库选择成功");
        }else{
            return error_show(1004,"备库单仓库选择失败");
        }
    }

    //备库单生成采购单
    public function createCgd(){
        $bk_code=isset($this->post['bk_code'])&&$this->post['bk_code']!=="" ? trim($this->post['bk_code']):"";
        if($bk_code===""){
            return error_show(1004,"参数bk_code不能为空");
        }
        $info = Db::name("purchease")->where(["bk_code"=>$bk_code,"is_del"=>0])->find();
        if($info==false){
            return error_show(1002,'未找到备库数据');
        }
        $wsm_code =isset($this->post['wsm_code'])&&$this->post['wsm_code']!=="" ? trim($this->post['wsm_code']):'';
        if($wsm_code==""){
            return error_show(1002,'备库仓库不能为空');
        }
        $wsminfo = Db::name("warehouse_info")->where(["wsm_code"=>$wsm_code,"is_del"=>0])->find();
        if($wsminfo==false){
            return error_show(1002,'备库仓库未找到');
        }
        $good =Db::name("good_basic")->where([["spuCode","=",$info['spuCode']],["is_del","=",0]])->find();
        if($good==false){
            return error_show(1004,"未找到商品数据");
        }
        $supplier=Db::name("supplier")->where(["code"=>$info['supplierNo'],"is_del"=>0])->find();
        if($supplier==false){
            return error_show(1004,"未找到供应商数据");
        }
        $goodnake =Db::name("good_nake")->where([["spuCode","=",$info['spuCode']],["is_del","=",0],["min_num","<=",
            $info['good_num']]])->order("min_num desc")->find();
        if($goodnake==false){
            return error_show(1004,"未找到成本数据");
        }
        $top_cat = made($good['cat_id']);
        $top_cat_id = isset($top_cat[0]['id'])?$top_cat[0]['id']:"";
        if($good['is_gold_price']==1 && $top_cat_id==6){
            $gold = Db::name("gold_price1")->where(["type"=>$good['noble_metal'],"is_del"=>0,"status"=>1])->order("addtime desc")
                ->find();
          //  $weight =  $good['noble_weight']*$info['good_num'];
            $sale_price =  round($good['demo_fee'] / $info['good_num'] + $good['open_fee'] / $info['good_num'] + $good['noble_weight'] * $gold["price"] + $goodnake['cost_fee'] * $good['noble_weight']  + $goodnake['package_fee'] +  $goodnake['mark_fee'] + $goodnake['cert_fee'] +$goodnake['nake_fee'] + $goodnake['delivery_fee'],2);
            $total_price = round($info['good_num']*$sale_price,2);
        }else{
            $sale_price = $goodnake['nake_total'];
            $total_price = round($info['good_num']*$sale_price,2);
        }

        $cgdCode = makeNo("CG");

        $cg =["cgdNo"=>$cgdCode,
            "bkcode"=>$bk_code,
            "wsm_code"=>$wsm_code,
            "cgder"=>$good['creater'],
            "cgder_id"=>$good['createrid'],
            "spuCode"=>$info['spuCode'],
            "good_name"=>$info['good_name'],
            "good_num"=>$info['good_num'],
            "good_price"=>$sale_price,
            "total_fee"=>$total_price,
            "pakge_fee"=>isset($goodnake['package_fee'])? $goodnake['package_fee']:0,
            "cert_fee"=>isset($goodnake['cert_fee'])? $goodnake['cert_fee']:0,
            "open_fee"=>$good['open_fee'],
            "delivery_fee"=>isset($goodnake['delivery_fee'])? $goodnake['delivery_fee']:0,
            "mark_fee"=>isset($goodnake['mark_fee'])? $goodnake['mark_fee']:0,
            "nake_fee"=>isset($goodnake['nake_fee'])? $goodnake['nake_fee']:0,
            "teach_fee"=>isset($goodnake['cost_fee'])? $goodnake['cost_fee']:0,
            "demo_fee"=>$good['demo_fee'],
            "diff_weight"=>"0",
            "diff_fee"=>"0",
            "gold_price"=>"0",
            "supplierNo"=>$info['supplierNo'],
            "supplier_name"=>$supplier['name'],
            "companyNo"=>$info['companyNo'],
            "send_status"=>1,
            "send_num"=>"0",
            "wsend_num"=>$info['good_num'],
            "weight"=>$good['noble_weight'],
            "remark"=>"",
            "status"=>0,//0表示初始化
            "lasttime"=>$info['lasttime'],
            "is_del"=>0,
            "order_type" => 1,//1备库
            "order_source" => 0,//0备库下单
            "good_type"=>1,
            "addtime"=>date("Y-m-d H:i:s"),
            "updatetime"=>date("Y-m-d H:i:s"),
            'good_createrid' => $good['createrid'],
            'good_creater' => $good['creater'],//商品创建人
        ];
        Db::startTrans();
        try{
            $up =Db::name("purchease_order")->insert($cg,true);
            if($up>0){
                    $good = Db::name("good_stock")->where(["wsm_code" =>$wsm_code, "spuCode" => $info['spuCode'], "is_del" => 0])->find();
                    if ($good == false) {
                        $good = [
                            "spuCode" => $info['spuCode'],
                            "wsm_code" => $wsm_code,
                            "usable_stock" => 0,
                            "wait_out_stock" => 0,
                            "wait_in_stock" => 0,
                            "total_stock" => 0,
                            "addtime" => date("Y-m-d H:i:s"),
                            "updatetime" => date("Y-m-d H:i:s"),
                        ];
                        $order = ["order_code" => $info['spuCode'], "status" => 1, "action_remark" => '', "action_type" => "create"];
                    } else {
                        $order = ["order_code" => $info['spuCode'], "status" => 1, "action_remark" => '', "action_type" => "edit"];
                    }
                    $good['wait_in_stock'] += $info['good_num'];
                    $good['updatetime'] = date("Y-m-d H:i:s");
                    $upd = Db::name("good_stock")->save($good);
                    $good_data[] = ['good_log_code' => $cgdCode,"stock_id" => isset($good['id']) ? $good['id'] : Db::name("good_stock")->getLastInsID(), "type" => 1,
                        'stock' => $info['good_num'], "stock_name" => "wait_in_stock"];
                    if ($upd) {
                   // 商品变动日志表，good_log_code字段存储采购单号
                        $order = ["order_code" =>  $cgdCode, "status" => 0, "action_remark" => '', "action_type" => "create"];
                        GoodLog::LogAdd($this->post['token'], $good_data, 'CGD');
                        ActionLog::logAdd($this->post['token'], $order, "CGD", 0, $good);
                        $process = ["order_code" => $cgdCode, "order_id" => $up, "order_status" => $cg['status'], "order_type" => 'CGD',"before_status"=>0,'holder_id'=>$supplier['personid'],'wait_id'=>$supplier['personid'],'wait_name'=>$supplier['person']];
                        ProcessOrder::AddProcess($this->post['token'], $process);
                        $info['wsm_code'] = $wsm_code;
                        $old_info_status = $info['status'];
                        $info['status'] = 2;
                        $info['updatetime'] = date("Y-m-d H:i:s");
                        $bas = Db::name("purchease")->save($info);
                        if ($bas) {

                            //修改状态，添加待办
                            ActionLog::logAdd($this->post['token'], [
                                "order_code" => $info['bk_code'],//销售单code
                                "status" => $old_info_status,//这里的status是之前的值
                                "action_remark" => '',//备注
                                "action_type" => "edit"//新建create，编辑edit，更改状态status
                            ], "BHD", $info['status'], $info);

                            ProcessOrder::AddProcess($this->post['token'], [
                                "order_type" => 'BHD',
                                "order_code" => $info['bk_code'],//销售单code
                                "order_id" => $info['id'],
                                "order_status" => $info['status'],
                                "before_status"=> $old_info_status,
                                'holder_id' => $info['apply_id']
                            ]);

                            //维护台账记录
                            Db::name('standing_book')->where('bk_code', $bk_code)->update([
                                'spuCode' => $cg['spuCode'],
                                'order_type' => $cg['order_type'],
                                'order_source' => $cg['order_source'],
                                'supplierNo' => $cg['supplierNo'],
                                'companyNo' => $cg['companyNo'],
                                'cgdNo' => $cg['cgdNo'],
                                'updatetime' => date('Y-m-d H:i:s'),
                            ]);

                            //将采购单数据塞入到队列中
                            $push_data = json_encode([
                                'supplierNo' => $cg['supplierNo'],
                                'type' => 1,//1销售订单(采销的采购单),2上线结果
                                'data' => [
                                    'cgdNo' => $cg['cgdNo'],
                                    'spuCode' => $cg['spuCode'],
                                    'good_name' => $cg['good_name'],
                                    'good_num' => $cg['good_num'],
                                    'good_price' => $cg['good_price'],
                                    'total_fee' => $cg['total_fee'],
                                    'weight' => $cg['weight'],
                                    'addtime' => $cg['addtime'],
                                ],
                            ], JSON_UNESCAPED_UNICODE);
//                            Cache::store("redis")->handler()->lPush(Config::get('app.abutment_queue'), $push_data);

                            Db::commit();
                            return app_show(0, "采购单新建成功", ["cgdNo" => $cgdCode]);
                        }

                    }
//                    }
                }
                Db::rollback();
                return error_show(1004,"采购单新建失败");
        }catch (\Exception $e){
            Db::rollback();
            return error_show(1004,$e->getMessage());
        }
    }
}