|
@@ -0,0 +1,69 @@
|
|
|
+<?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());
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+}
|