phpstock/app/command/ImportOrderFromCHandleData.php

<?php
declare (strict_types=1);

namespace app\command;

use app\admin\model\ActionLog;
use app\admin\model\GoodLog;
use app\admin\model\OrderImportFromC as OIFCModel;
use app\admin\model\ProcessOrder;
use app\admin\model\Test1;
use think\console\Command;
use think\console\Input;
use think\console\input\Argument;
use think\console\input\Option;
use think\console\Output;
use think\Exception;
use think\facade\Cache;
use think\facade\Db;

//C端订单导入-处理
class ImportOrderFromCHandleData extends Command
{
    protected function configure()
    {
        // 指令配置
        $this->setName('handleData')
            ->setDescription('批量处理C端导入的订单数据');
    }

    //【脚本2】批量处理C端导入的订单数据
    protected function execute(Input $input, Output $output)
    {

        $key = 'import_order_from_c_key';
        $c_data_id = Cache::store('redis')->handler()->rpop($key);

        if (!$c_data_id) $output->writeln('没有符合条件的记录');
        else {
            $order_import_from_c_db = new OIFCModel();

            $c_data = $order_import_from_c_db
                ->where(['is_del' => OIFCModel::$is_del_normal, 'status' => OIFCModel::$status_wait_relation, 'id' => $c_data_id])
                ->lock(true)
                ->field('id,createrid,creater')
                ->find();

            if (empty($c_data)) $output->writeln('未查询到该记录');
            else {

                Db::startTrans();
                try {

                    //先找用户确认信息
                    $extend_data = Db::name('order_import_from_c_extend')
                        ->where(['order_import_from_c_id' => $c_data['id'], 'is_del' => 0, 'type' => 2])
                        ->find();
                    if (empty($extend_data)) {
                        $extend_data = Db::name('order_import_from_c_extend')
                            ->where(['order_import_from_c_id' => $c_data['id'], 'is_del' => 0, 'type' => 1])
                            ->find();
                    }

                    if (empty($extend_data)) throw new Exception('没有对应的解析数据');

                    //复用sale::create()方法 -- start

                    $orderCode = makeNo("QR");
                    $customer_code = $extend_data['customer_code'];

                    $customer = Db::name("customer_info")
                        ->where(["companyNo" => $customer_code])
                        ->find();

                    if ($customer == false) throw new Exception('未找到客户数据');

                    $supplierNo = $extend_data['companyNo'];
                    $supplier = Db::name("business")
                        ->where(["companyNo" => $supplierNo])
                        ->find();
                    if ($supplier == false) throw new Exception('未找到平台供应商数据');

                    $goodtype = 1;//1正常商品

                    $sendtype = 1;//直接发货
                    $platform_id = $extend_data['platform_id'];

                    $platform_order = $extend_data['platform_code'];
                    $good_num = $extend_data['num'];
                    $arrtime = $extend_data['platform_time'];
                    $paytime = $extend_data['addtime'];
                    $workNo = $extend_data['po_code'];
                    $ct = Db::name('good_platform')
                        ->alias('a')
                        ->join('good b', 'b.spuCode=a.spuCode', 'left')
                        ->where(['a.skuCode' => $extend_data['skuCode'], 'a.exam_status' => 6])//exam_status==6已上线
                        ->field("b.*,a.skuCode,a.spuCode,a.platform_code,a.plat_code")
                        ->find();
                    if ($ct == false) throw new Exception('未找到商品数据');

                    $goodinfo = $ct;
                    $is_stock = $ct['is_stock'];
                    $order_type = $is_stock == 1 ? 5 : 6;//1销售2咨询(1备库 2非库存 3咨询采反 4项目采反,5平台部订单销售库存品,6平台部订单销售非库存品)
                    $spuCode = $ct['spuCode'];
                    $skuCode = $ct['skuCode'];
                    $is_activity = empty($extend_data['activity_name']) ? 0 : 1;

                    if ($goodinfo['is_stock'] == 1) {
                        $stock = Db::name("good_stock")
                            ->alias("a")
                            ->leftJoin("warehouse_info b", "a.wsm_code=b.wsm_code")
                            ->where(["spuCode" => $spuCode, "a.is_del" => 0, "a.status" => 1, 'b.wsm_type' => 5, "b.companyNo" => $supplierNo])
                            ->field("a.id,a.usable_stock,a.wait_out_stock")
                            ->find();

                        if ($stock == false || $stock['usable_stock'] < $good_num) throw new Exception('库存数量不足');

                        $origin_price = 0;

                    } else {

                        $origin = Db::name("good_nake")
                            ->where([["spuCode", "=", $spuCode], ["min_num", "<=", $good_num], ["is_del", "=", 0]])
                            ->order("min_num desc")
                            ->find();
                        if ($origin == false) throw new Exception('未找到相关成本价格');

                        $origin_price = $origin['nake_total'];

                    }

                    $sale_price = $extend_data['price'];
                    if ($goodtype == 1) {
                        $good = Db::name("good_ladder")
                            ->where(["skuCode" => $skuCode, "is_del" => 0, "status" => 1])
                            ->where([["min_num", "<=", $good_num]])
                            ->order("min_num desc")
                            ->find();
                        if ($good == false) throw new Exception('未找到相关阶梯价格');

                        $sale_price = $good['sale_price'];
                        if ($ct['is_gold_price'] == 1 && $is_stock != 1) {
                            $gold = Db::name("gold_price1")
                                ->field('id,price')
                                ->where(["type" => $ct['noble_metal'], "is_del" => 0, "status" => 1])
                                ->order("addtime desc")
                                ->find();

                            //$saleprice(最终售价) = （打样费/购买数量 + 开模费/购买数量 + 商品重量* 最新金价 + 工艺费* 商品重量+包装费+加标费+证书费+产品裸价+物流费）/(1-成本售价/100);
                            $sale_price = $ct['demo_fee'] / $good_num + $ct['open_fee'] / $good_num + $ct['noble_weight'] * $gold["price"] + $good['cost_fee'] * $ct['noble_weight'] + $origin['package_fee'] + $origin['mark_fee'] + $origin['cert_fee'] + $origin['nake_fee'] + $origin['delivery_fee'];

                            $ct['cgd_gold_price'] = $gold['price'];

//                $order_rate = Db::name("cat")->where(["id" => $ct['cat_id']])->value('order_rate');
//                $budget = isset($order_rate) ? $order_rate / 100 : 0;

                            // $saleprice = $total_fee / (1 - $budget);
                        }

                        if ($is_activity == 1) {
                            $act = Db::name("activity_info")
                                ->alias("a")
                                ->leftJoin("good_activity b", "a.activity_code=b.activity_code")
                                ->where(["a.skuCode" => $skuCode, "a.activity_code" => $extend_data['activity_code'], "a.is_del" => 0, "a.status" => 1, "b.status" => 6, "b.is_del" => 0])
                                ->find();
                            if ($act == false) throw new Exception('未找到相关活动价');
                            if ($act['moq_num'] > $good_num) throw new Exception('商品不满足活动价起订量' . $act['moq_num']);
                            if ($act['activity_stock'] < $good_num) throw new Exception('商品活动库存剩余' . $act['activity_stock']);
                            $sale_price = $act['activity_price'];
                        }
                    }
                    $cgd = [
                        "supplierNo" => $ct['supplierNo'],
                        "companyNo" => $supplierNo,
                        "orderCode" => $orderCode,
                        "spuCode" => $ct['spuCode'],
                        "skuCode" => $ct['skuCode'],
                        "good_name" => $ct['good_name'],
                        "sale_price" => $origin_price,
                        "total_fee" => $origin_price * $good_num,
                        "pakge_fee" => $ct['packing_fee'],
                        "cert_fee" => $ct['cert_fee'],
                        "open_fee" => $ct['open_fee'],
                        "cost_fee" => $ct['cost_fee'],
                        "mark_fee" => $ct['mark_fee'],
                        "demo_fee" => $ct['demo_fee'],
                        "good_num" => $good_num,
                        "good_type" => $goodtype,
                        "order_type" => $order_type,
                        "createrid" => $ct['createrid'],
                        "creater" => $ct['creater'],
                        'send_way' => 2
                    ];

                    $send_num = $extend_data['num'];
                    $remark = $extend_data['order_remark'];
                    $rm = $c_data['createrid'];
                    $ri = $c_data['creater'];
                    $data = [
                        "orderCode" => $orderCode,
                        "good_code" => $spuCode,
                        "skuCode" => $skuCode,
                        "customer_code" => $customer_code,
                        "good_name" => isset($goodinfo['good_name']) && $goodinfo['good_name'] !== '' ? $goodinfo['good_name'] : '',
                        "good_num" => $good_num,
                        "cat_id" => $goodinfo['cat_id'],
                        "apply_id" => $rm,
                        "apply_name" => $ri,
                        "origin_price" => $origin_price,
                        "sale_price" => $sale_price,
                        "post_fee" => 0,
                        "status" => 0,
                        "send_num" => 0,
                        "wsend_num" => $good_num,
                        "send_status" => 1,
                        "good_type" => $goodtype,
                        "send_type" => $sendtype,
                        "supplierNo" => $extend_data['companyNo'],
                        "is_del" => 0,
                        "zxNo" => "",
                        "platform_order" => $platform_order,
                        "platform_id" => $platform_id,
                        "remark" => $remark,
                        "is_stock" => $is_stock,
                        "is_activity" => $is_activity === "" ? 0 : $is_activity,
                        "order_type" => $order_type,
//                "poNo"=>$poNo,
                        'good_weight' => $ct['weight'],
                        'gold_price' => $ct['cgd_gold_price'],
                        'cost_price' => $ct['cost_fee'],
                        'diff_weight' => 0,
                        'diff_fee' => 0,
                        "workNo" => $workNo,
                        "addtime" => date("Y-m-d H:i:s"),
                        "updatetime" => date("Y-m-d H:i:s"),
                        'total_price' => round($sale_price * $good_num, 2),
                    ];
                    $paytime == "" ? "" : $data['paytime'] = $paytime;
                    $datainfo = Db::name('sale')->insert($data, true);
                    if ($datainfo > 0) {
                        if ($is_activity == 1) {
                            $actup = [
                                "activity_stock" => $act['activity_stock'] - $good_num,
                                "updatetime" => date("Y-m-d H:i:s")
                            ];
                            $actupp = Db::name("activity_info")
                                ->where(["skuCode" => $skuCode, "activity_code" => $extend_data['activity_code'], "is_del" => 0, "status" => 1])
                                ->save($actup);
                            if ($actupp == false) throw new Exception('活动库存修改失败');

                        }
                        if ($is_stock == 0) {

                            //非库存品
                            $bol = $this->createCgd($cgd, $rm, $ri);
                            if ($bol == false) throw new Exception('订单创建失败');

                        } else {
                            //库存品
                            $bol = $this->RelaCgd(['orderCode' => $orderCode, "good_num" => $good_num, "spuCode" => $spuCode, "companyNo" => $supplierNo, 'order_type' => $order_type]);
                            if ($bol == false) throw new Exception('库存商品关联采购单失败');

                            if (isset($stock)) {
                                $stck = [
                                    "usable_stock" => $stock['usable_stock'] - $good_num,
                                    "wait_out_stock" => $stock['wait_out_stock'] + $good_num,
                                    "updatetime" => date("Y-m-d H:i:s")
                                ];
                                $upad = Db::name("good_stock")
                                    ->where($stock)
                                    ->update($stck);
                                if ($upad == false) throw new Exception('库存商品更新库存失败');

                                //商品变动日志表，good_log_code字段存储采购单号
                                $good_data[] = ['good_log_code' => $orderCode, "stock_id" => $datainfo, "type" => 2, 'stock' => $good_num, "stock_name" => "usable_stock"];
                                $good_data[] = ['good_log_code' => $orderCode, "stock_id" => $datainfo, "type" => 1, 'stock' => $good_num, "stock_name" => "wait_out_stock"];
                                GoodLog::LogAdd(['id' => $rm, 'nickname' => $ri], $good_data, "XSQRD");
                            }

                        }
                        if ($sendtype == 1) {
                            $temp = [
                                'orderCode' => $orderCode,
                                'contactor' => $extend_data['contactor'],
                                'mobile' => $extend_data['mobile'],
                                'addr' => $extend_data['addr'],
                                'addr_code' => $extend_data['addr_code'],
                                'customer_code' => $customer_code,
                                'receipt_quantity' => $extend_data['num'],//收货数量,
                                'post_fee' => 0,
                                'is_del' => 0,
                                'addtime' => date("Y-m-d H:i:s"),
                                'updatetime' => date("Y-m-d H:i:s"),
                                'arrive_time' => $arrtime,
                            ];
                            $vmp = Db::name('order_addr')->insert($temp, true);
                            if ($vmp > 0) {
                                $order = Db::name("order_num")
                                    ->where(["orderCode" => $orderCode, "status" => 1])
                                    ->where([["wsend_num", ">=", 0]])
                                    ->lock(true)
                                    ->find();
                                if ($order == false) throw new Exception('未找到可以发货得采购单数据');


                                $num = $extend_data['num'];
                                $outCode = makeNo("DF");
                                $order['wsend_num'] -= $num;
                                $order['send_num'] += $num;
                                $or = Db::name("order_num")->save($order);
                                if ($or == false) throw new Exception('发货地址更新失败');

                                $tep = [
                                    "cgdNo" => $order['cgdNo'],
                                    "outCode" => $outCode,
                                    "send_num" => $num,
                                    "status" => 1,
                                    "addtime" => date("Y-m-d H:i:s"),
                                    "updatetime" => date("Y-m-d H:i:s")
                                ];
                                $sen = Db::name("order_send")->save($tep);
                                if ($sen == false) throw new Exception('发货地址添加创建失败');

                                $cgdinfo = Db::name("purchease_order")->where(["cgdNo" => $order['cgdNo']])->find();
                                if ($cgdinfo == false) throw new Exception('未匹配到采购数据');

                                $out = [
                                    "orderCode" => $orderCode,
                                    "outCode" => $outCode,
                                    "apply_id" => $rm,
                                    "apply_name" => $ri,
                                    "addrid" => $vmp,
                                    "post_name" => "",
                                    "post_code" => "",
                                    "post_fee" => 0,
                                    "sendtime" => date("Y-m-d H:i:s"),
                                    "send_num" => $num,
                                    "check_num" => 0,
                                    "error_num" => 0,
                                    "wsm_code" => $cgdinfo['wsm_code'],
                                    "order_type" => $order_type,
                                    "status" => $is_stock == 1 ? 1 : 0,
                                    "addtime" => date("Y-m-d H:i:s"),
                                    "updatetime" => date("Y-m-d H:i:s")
                                ];
                                $ou = Db::name("order_out")->insert($out);
                                if ($ou == false) throw new Exception('发货地址添加创建失败');
                                else {
                                    //修改状态，添加待办
                                    ActionLog::logAdd(['id' => $rm, 'nickname' => $ri], [
                                        "order_code" => $outCode,//出库单号
                                        "status" => 0,//这里的status是之前的值
                                        "action_remark" => '',//备注
                                        "action_type" => "create"//新建create，编辑edit，更改状态status
                                    ], "CKD", 0, $out);

                                    ProcessOrder::AddProcess(['id' => $rm, 'nickname' => $ri], [
                                        "order_type" => 'CKD',
                                        "order_code" => $outCode,//出库单号
                                        "order_id" => 0,
                                        "order_status" => 0,
                                        "before_status" => 0
                                    ]);
                                }
                            } else throw new Exception('发货地址添加失败');
                        }
                    }

                    //复用sale::create()方法 -- end

                    //处理完成
                    $order_import_from_c_db
                        ->where('id', $c_data['id'])
                        ->where('is_del', OIFCModel::$is_del_normal)
                        ->save([
                            'status' => $order_import_from_c_db::$status_success,
                            'updatetime' => date('Y-m-d H:i:s'),
                            'remark' => '',
                            'updateid' => 0,
                            'updater' => 'system',
                            'orderCode' => $orderCode
                        ]);

                    Db::commit();

                    $output->writeln(date('Y-m-d H:i:s') . '|处理成功');

                } catch (\think\Exception $exception) {
                    Db::rollback();
                    $order_import_from_c_db
                        ->where(['id' => $c_data['id'], 'status' => OIFCModel::$status_wait_relation])
                        ->save([
                            'status' => $order_import_from_c_db::$status_stock_not_enough,
                            'updatetime' => date('Y-m-d H:i:s'),
                            'remark' => $exception->getMessage(),
                            'updateid' => 0,
                            'updater' => 'system'
                        ]);
                    // 指令输出
                    $output->writeln(date('Y-m-d H:i:s') . '|处理失败，' . $exception->getMessage() . '|' . $exception->getFile() . '|' . $exception->getLine());
                }
            }
        }

    }


    //创建采购单
    private function createCgd($data = [], $rm = '0', $ri = '')
    {
        $cgdCode = makeNo("CG");
        $supplier = Db::name("supplier")
            ->where(["code" => $data['supplierNo'], "is_del" => 0])->find();
        if ($supplier == false) return false;

        $wsm = Db::name("warehouse_info")
            ->where(["supplierNo" => $data["supplierNo"], "companyNo" => $data['companyNo'], "is_del" => 0])
            ->find();
        if ($wsm == false) {
            $wsm_code = makeNo("WSM");
            $inwsm = [
                "wsm_code" => $wsm_code,
                "name" => $supplier['name'],
                "wsm_type" => 2,
                "supplierNo" => $supplier['code'],
                "addr" => "",
                "addrs_code" => "",
                "contactor" => 0,
                "contactor_name" => 0,
                "mobile" => "",
                "position" => "",
                "companyNo" => $data['companyNo'],
                "status" => 1,
                "is_del" => 0,
                "addtime" => date("Y-m-d H:i:s"),
                "updatetime" => date("Y-m-d H:i:s")
            ];
            $in = Db::name("warehouse_info")->insert($inwsm);
            if ($in == false) return false;

        } else {
            $wsm_code = $wsm['wsm_code'];
        }

        $cg = [
            "cgdNo" => $cgdCode,
            "bkcode" => "",
            "wsm_code" => $wsm_code,
            "cgder" => $data['creater'],
            "cgder_id" => $data['createrid'],
            "spuCode" => $data['spuCode'],
            "skuCode" => $data['skuCode'],
            "good_name" => $data['good_name'],
            "good_num" => $data['good_num'],
            "good_price" => $data['sale_price'],
            "total_fee" => round($data['sale_price'] * $data['good_num'], 2),
            "pakge_fee" => $data['pakge_fee'],
            "cert_fee" => $data['cert_fee'],
            "open_fee" => $data['open_fee'],
            "teach_fee" => $data['cost_fee'],
            "mark_fee" => $data['mark_fee'],
            "demo_fee" => $data['demo_fee'],
            #"weight"=>$data['weight'],
            "diff_weight" => "0",
            "diff_fee" => "0",
            "gold_price" => "0",
            "supplierNo" => $data['supplierNo'],
            "supplier_name" => $supplier['name'],
            "companyNo" => $data['companyNo'],
            "send_status" => 1,
            "send_num" => 0,
            "wsend_num" => $data['good_num'],
            "remark" => "",
            "status" => 0,//0初始化
            "lasttime" => date("Y-m-d H:i:s"),
            "is_del" => 0,
            "order_type" => $data['order_type'],
            "good_type" => $data['good_type'],
            "addtime" => date("Y-m-d H:i:s"),
            "updatetime" => date("Y-m-d H:i:s")
        ];
        $up = Db::name("purchease_order")->insert($cg, true);
        if ($up) {

            //修改状态，添加待办
            ActionLog::logAdd(['id' => $rm, 'nickname' => $ri], [
                "order_code" => $cg['cgdNo'],//销售单code
                "status" => 0,//这里的status是之前的值
                "action_remark" => '',//备注
                "action_type" => "create"//新建create，编辑edit，更改状态status
            ], "CGD", $cg['status'], $cg);

            ProcessOrder::AddProcess(['id' => $rm, 'nickname' => $ri], [
                "order_type" => 'CGD',
                "order_code" => $cg['cgdNo'],//销售单code
                "order_id" => $up,
                "order_status" => $cg['status'],
                "before_status" => 0
            ]);

            $rela = [
                "orderCode" => $data['orderCode'],
                "cgdNo" => $cgdCode,
                "spuCode" => $data['spuCode'],
                "good_num" => $data['good_num'],
                "wsend_num" => $data['good_num'],
                "send_num" => 0,
                "wait_num" => 0,
                "status" => 1,
                "source" => 2
            ];
            $re = Db::name("order_num")->save($rela);
            if ($re == false) return false;
            else {
                $stokc = Db::name("good_stock")
                    ->where(['spuCode' => $data['spuCode'], "wsm_code" => $wsm_code, "is_del" => 0])
                    ->find();
                if ($stokc == false) {
                    $stokc = [
                        "spuCode" => $data['spuCode'],
                        "wsm_code" => $wsm_code,
                        "wait_in_stock" => 0,
                        "wait_out_stock" => 0,
                        "usable_stock" => 0,
                        "intra_stock" => 0,
                        "total_stock" => 0,
                        "status" => 1,
                        "addtime" => date("Y-m-d H:i:s"),
                        "updatetime" => date("Y-m-d H:i:s")
                    ];
                    $stoc = Db::name("good_stock")->save($stokc);
                    if ($stoc == false) return false;

                }

                return true;
            }
        } else return false;

    }


    //创建.....
    private function RelaCgd(array $outinfo = [])
    {
        //备库单
        $cgd = Db::name("order_bk")
            ->where([
                ["spuCode", "=", $outinfo['spuCode']],
                ["is_del", "=", 0],
                ["balance_num", ">=", $outinfo['good_num']],
                ['companyNo', "=", $outinfo['companyNo']]
            ])
            ->lock(true)
            ->find();

        if ($cgd == false) return false;

        $cgdinfo = Db::name("purchease_order")
            ->where(['cgdNo' => $cgd['cgdNo'], "is_del" => 0])
            ->find();
        if ($cgdinfo == false) return false;

        $QrdCgd = [
            "cgdNo" => makeNo("CG"),
            "bkcode" => $cgdinfo['bkcode'],
            'wsm_code' => $cgdinfo['wsm_code'],
            "cgder_id" => $cgdinfo['cgder_id'],
            "cgder" => $cgdinfo['cgder'],
            "spuCode" => $cgdinfo['spuCode'],
            "good_name" => $cgdinfo['good_name'],
            "good_num" => $outinfo['good_num'],
            "good_price" => $cgdinfo['good_price'],
            "total_fee" => round($cgdinfo['good_price'] * $outinfo['good_num'], 2),
            "pakge_fee" => $cgdinfo['pakge_fee'],
            "cert_fee" => $cgdinfo['cert_fee'],
            "open_fee" => $cgdinfo['open_fee'],
            "delivery_fee" => $cgdinfo['delivery_fee'],
            "mark_fee" => $cgdinfo['mark_fee'],
            "teach_fee" => $cgdinfo['teach_fee'],
            "nake_fee" => $cgdinfo['nake_fee'],
            "demo_fee" => $cgdinfo['demo_fee'],
            "weight" => $cgdinfo['weight'],
            "diff_weight" => $cgdinfo['diff_weight'],
            "diff_fee" => $cgdinfo['diff_fee'],
            "gold_price" => $cgdinfo['gold_price'],
            "supplierNo" => $cgdinfo['supplierNo'],
            "supplier_name" => $cgdinfo['supplier_name'],
            "companyNo" => $cgdinfo['companyNo'],
            "send_status" => 3,
            "send_num" => $outinfo['good_num'],
            "wsend_num" => 0,
            "remark" => $cgdinfo['remark'],
            "status" => 3,//入库完成
            "lasttime" => $cgdinfo['lasttime'],
            "is_del" => 0,
            "order_type" => $outinfo['order_type'],
            "good_type" => $cgdinfo['good_type'],
            "addtime" => date("Y-m-d H:i:s"),
            "updatetime" => date("Y-m-d H:i:s")
        ];
        $insetrCgd = Db::name("purchease_order")->insert($QrdCgd);
        if ($insetrCgd == false) return false;

        $merge_num = Db::name("purchease_order")
            ->where(["bkcode" => $cgdinfo['bkcode'], "order_type" => $outinfo['order_type'], "is_del" => 0])
            ->field("sum(send_num)-sum(th_num) as num")
            ->find();
        $cgd['balance_num'] = $cgd['total_num'] - $merge_num['num'];
        $cgd['merge_num'] = $merge_num['num'];
        $cgd['updatetime'] = date("Y-m-d H:i:s");
        $up = Db::name("order_bk")->save($cgd);
        if ($up == false) return false;

        $data = [
            "orderCode" => $outinfo['orderCode'],
            "cgdNo" => $QrdCgd['cgdNo'],
            "spuCode" => $outinfo['spuCode'],
            "companyNo" => $outinfo['companyNo'],
            "good_num" => $outinfo['good_num'],
            "wsend_num" => $outinfo['good_num'],
            "send_num" => 0,
            "wait_num" => $outinfo['good_num'],
            "status" => 1,
            "source" => 1,
        ];
        $order = Db::name("order_num")->save($data);
        if ($order == false) return false;

        return true;
    }


}