phpstock/app/admin/controller/Salezx.php

<?php


namespace app\admin\controller;
use think\App;
use think\facade\Db;
class Salezx extends \app\BaseController
{
    public $post="";
    public function __construct(App $app)
    {
        parent::__construct($app);
        $this->post=$this->request->post();
    }

    public function create(){
        $token = isset($this->post['token']) && $this->post['token'] !=="" ?trim($this->post['token']):"";
        $orderCode=makeNo("CX");
        $zxNo=isset($this->post['zxNo']) && $this->post['zxNo'] !=="" ?trim($this->post['zxNo']):"";
        if($zxNo==''){
            return error_show(1004,"参数zxNo不能为空");
        }
        $zxinfo = Db::name("consult")->where(["zxNo"=>$zxNo,"is_del"=>0])->find();
        if($zxinfo==false){
            return error_show(1004,"未找到咨询单数据");
        }
        $customer_code= $this->post['customer_code'] && $this->post['customer_code'] !=="" ? trim($this->post['customer_code']) :"";
        if($customer_code==""){
            return error_show(1002,"客户code不能为空");
        }
        $customer=Db::name("customer_info")->where(["companyNo"=>$customer_code])->find();
        if($customer==false){
            return error_show(1004,"未找到客户数据");
        }
        $supplierNo= $this->post['supplierNo'] && $this->post['supplierNo'] !=="" ? trim($this->post['supplierNo']) :"";
        if($supplierNo==""){
            return error_show(1002,"参数supplierNo不能为空");
        }
        $supplier=Db::name("supplier")->where(["code"=>$supplierNo])->find();
        if($supplier==false){
            return error_show(1004,"未找到平台供应商数据");
        }
        $wsm=Db::name("warehouse_info")->where(["supplierNo"=>$zxinfo['gsyNo'],"wsm_type"=>2])->find();
        if(empty($wsm)){
            return error_show(1004,"未找到供应商仓库数据");
        }
        $sendtype =isset($this->post['sendtype']) && $this->post['sendtype'] !=="" ?trim($this->post['sendtype']):"";
        if($sendtype==''){
            return error_show(1004,"参数sendtype不能为空");
        }
        $good_num =isset($this->post['good_num']) && $this->post['good_num'] !=="" ?intval($this->post['good_num']):"";
        if($good_num===''){
            return error_show(1004,"参数good_num不能为空");
        }
        $goodtype =isset($this->post['goodtype']) && $this->post['goodtype'] !=="" ?intval($this->post['goodtype']):"";
        if($goodtype===''){
            return error_show(1004,"参数goodtype不能为空");
        }
        $remark =isset($this->post['remark']) && $this->post['remark'] !=="" ?trim($this->post['remark']):"";
        if($sendtype!=2){
            $addrlist = isset($this->post['addrlist']) && $this->post['addrlist'] !=="" ?$this->post['addrlist']:"";
            if($addrlist=="" || empty($addrlist)){
                return error_show(1004,"参数addrlist不能为空");
            }
        }

        $apply_id =GetUserInfo($token);
        if(empty($apply_id)||$apply_id['code']!=0){
            return error_show(1002,"申请人数据不存在");
        }
        $rm= isset($apply_id["data"]['id']) ?  $apply_id["data"]['id'] : "";
        $ri= isset($apply_id["data"]['nickname']) ?  $apply_id["data"]['nickname'] : "";
        Db::startTrans();
        try {
            $data=[
                "orderCode"=>$orderCode,
                "good_code"=>isset($zxinfo['cpNo'])&&$zxinfo['cpNo']!==''?$zxinfo['cpNo']:'',
                "customer_code"=>$customer_code,
                "good_name"=>isset($zxinfo['cpName'])&&$zxinfo['cpName']!==''?$zxinfo['cpName']:'',
                "good_num"=>$good_num,
                "apply_id"=>$rm,
                "apply_name"=>$ri,
                "origin_price"=>$zxinfo['sale_fee'],
                "sale_price"=>$zxinfo['sale_fee'],
                "post_fee"=>$zxinfo['delivery_fee'],
                "status"=>0,
                "send_num"=>0,
                "wsend_num"=>$good_num,
                "send_status"=>1,
                "good_type"=>$goodtype,
                "send_type"=>$sendtype,
                "supplierNo"=>$supplierNo,
                "is_del"=>0,
                "zxNo"=>$zxNo,
                "remark"=>$remark,
                "order_type"=>2,
                "addtime"=>date("Y-m-d H:i:s"),
                "updatetime"=>date("Y-m-d H:i:s"),
                'total_price'=>round($zxinfo['last_price']*$good_num,2),
            ];
            $datainfo = Db::name('sale')->insert($data,true);
            $vat=[];
            if($datainfo>0){
                $addgood=$this->addGood($zxinfo);
                if($addgood==false){
                    Db::rollback();
                    return error_show(1002,"咨询订单创建商品失败");
                }
                $saleinfo=[
                    "orderCode"=>$orderCode,
                    "wsm_code"=>$wsm['wsm_code'],
                    "num"=>$good_num,
                    "sale_price"=>$zxinfo['last_price'],
                    "total_price"=>round($zxinfo['last_price']*$good_num,2),
                    "addtime"=>date("Y-m-d H:i:s"),
                    "updatetime"=>date("Y-m-d H:i:s"),
                ];
                $info = Db::name("sale_info")->insert($saleinfo);
                if($info==false){
                    Db::rollback();
                    return error_show(1002,"咨询订单创建失败");
                }
                if($sendtype!=2){
                    foreach ($addrlist as $value){
                        $temp=[];
                        $addrs=[];
                        if($value['addr_code']!==''&&is_array($value['addr_code'])){
                            $addrs['provice_code'] = $value['addr_code'][0];
                            $addrs['city_code'] = $value['addr_code'][1];
                            $addrs['area_code'] = $value['addr_code'][2];
                            $addr = json_encode($addrs);
                        }else{
                            $addr = isset($value['addr_code'])?$value['addr_code']:'';
                        }
                        $temp['orderCode']=$orderCode;
                        $temp['contactor']=$value['contactor'];
                        $temp['mobile'] = $value['mobile'];
                        $temp['addr'] = $value['addr'];
                        $temp['addr_code']=$addr;
                        $temp['customer_code'] =$customer_code;
                        $temp['receipt_quantity']=$value['receipt_quantity'];
                        $temp['post_fee'] =0;
                        $temp['is_del'] =0;
                        $temp['addtime'] =date("Y-m-d H:i:s");
                        $temp['updatetime'] =date("Y-m-d H:i:s");
                        $temp['arrive_time']=$value['arrive_time'];
                        $vat[]=$temp;
                    }
                    $vmp = Db::name('order_addr')->insertAll($vat);
                    if($vmp){
                        Db::commit();
                        return error_show(0,"咨询订单创建成功");
                    }
                }else{
                    Db::commit();
                    return error_show(0,"咨询订单创建成功");
                }

            }
            Db::rollback();
            return error_show(1002,"咨询订单创建失败");
        }catch(\Exception $e){
            Db::rollback();
            return error_show(1005,$e->getMessage());
        }
    }

    /**咨询新建商品
     * @param $data
     * @return bool
     */
    public function addGood($data){
        $isgood = Db::name("good")->where(["good_code"=>"GD-".$data["cpNo"]])->find();
        if($isgood){
            return true;
        }
        $good=[
            "good_code"=>"GD-".$data["cpNo"],
            "item"=>'咨询订单',
            "good_name"=>$data["cpName"],
            "good_desc"=>$data["desc"],
            "brand"=>$data["brank"],
            "original_price"=>$data["sale_fee"],
            "cg_saler"=>$data["saler"],
            "good_type"=>$data["zxtype"],
            "unit"=>$data["unit"],
            "good_addr"=>$data["addr"],
            "gys_code"=>$data["gysNo"],
            "market_fee"=>$data["sale_fee"],
            "is_online"=>'产品上线',
            "sort_f"=>$data["cat_f"],
            "sort_s"=>$data["cat_s"],
            "cat_id"=>$data["cat_id"],
            "status"=>1,
            "is_del"=>0,
            "addtime"=>date("Y-m-d H:i:s"),
            "updatetime"=>date("Y-m-d H:i:s")
        ];
        $insert = Db::name("good")->insert($good);
        if($insert){
            $type=[
                "type_code"=>$data['cpNo'],
                "good_code"=>"GD-".$data["cpNo"],
                "color"=>$data["color"],
                "material"=>$data["material"],
                "attribute"=>$data["model"],
                "specs"=>$data["specs"],
                "is_diff"=>$data["is_diff"],
                "cert_fee"=>$data["cert_fee"],
                "packing_fee"=>$data["package_fee"],
                "mark_fee"=>$data["mark_fee"],
                "cost_fee"=>$data["bare_fee"],
                "logistics_fee"=>$data["delivery_fee"],
                "logistics"=>$data["delivery_day"],
                "min_num"=>$data["min_num"],
                "unit_price"=>$data["sale_price"],
                "status"=>1,
                "is_del"=>0,
                "addtime"=>date("Y-m-d H:i:s"),
                "updatetime"=>date("Y-m-d H:i:s"),
            ];
            $ert = Db::name("good_type")->insert($type);
            if($ert){
                return true;
            }
        }
        return false;
    }

//    public function CgdAdd($data){
//        $cgNo = makeNo("CG");
//
//    }
}