phpstock/app/admin/controller/OrderImport.php

<?php

namespace app\admin\controller;

use app\admin\model\OrderImportFromC as OIFCModel;
use app\BaseController;
use Exception;
use think\facade\Db;
use think\facade\Validate;

//C端订单导入及处理类
class OrderImport extends Base
{

    //订单导入
    public function import(){

        $list = $this->request->post('list',[],'trim');

        $val = Validate::rule([
            'platform_code|平台订单号'=>'require|length:0,255',
            'po_code|其他单号'=>'length:0,255',
            'platform_time|平台下单时间'=>'require|date',
            'sale_source|销售渠道'=>'require|length:0,255',
            'good_code|商品编号'=>'require|length:0,255',
            'price|单价'=>'require|float',
            'num|数量'=>'require|number',
            'before_discount_all_price|优惠前总金额'=>'require|float',
            'discount_price|优惠金额'=>'require|float',
            'after_price|商品优惠后金额'=>'require|float',
            'activity_name|优惠活动名称'=>'require|length:0,255',
            'mode|收费模式'=>'require|length:0,255',
            'order_remark|订单备注'=>'length:0,255',
            'contactor|收货人'=>'require|length:0,255',
            'mobile|联系电话'=>'require|length:0,20',
            'addr|联系地址'=>'require|length:0,255',
        ]);

        Db::startTrans();

        try{

            $insert_data=[];
            foreach ($list as $key=>$value){
                if(!$val->check($value)) throw new \think\Exception('第'.(string)($key+1).'行数据格式有问题，'.$val->getError());
                else $insert_data[]=$value;
            }

            $res = Db::name('order_import_from_c')
                ->limit(100)
                ->insertAll($insert_data);

            if($res){
                Db::commit();
                return app_show(0, "导入成功，共".(string)$res.'条记录');
            }else{
                Db::rollback();

                return error_show(1005,'导入失败');
            }

        }catch (Exception $exception){
            Db::rollback();
            return error_show(1005,$exception->getMessage());
        }

    }

}