文件导入测试

app/Http/Controllers/Api/OrderCostController.php

@@ -30,8 +30,7 @@ class OrderCostController extends Controller
         $file = $request->file('file');
 
        if($type==1) {
-            $res = OrderCostService::orderCostImportNew($file);
-//            $res = OrderCostService::orderCostImport($file);
+            $res = OrderCostService::orderCostImport($file);
 
             if ($res['code'] == 0) {
                 $not_exists = $res['not_exists'];

app/Services/OrderCostService.php

@@ -122,6 +122,8 @@ class OrderCostService{
                         'row' => $row,
                         'error' => $error
                     ];
+
+                    break;
                 }
             }
 
@@ -170,144 +172,6 @@ class OrderCostService{
         }
 	}
 
-    /**
-     * 订单导入
-     */
-    public static function orderCostImportNew($filePath) {
-        try {
-            ini_set("memory_limit",-1);
-            ini_set('max_execution_time', 3600);
-
-            $cacheMethod = \PHPExcel_CachedObjectStorageFactory:: cache_to_phpTemp;
-            $cacheSettings = array( ' memoryCacheSize ' => '8MB');
-            \PHPExcel_Settings::setCacheStorageMethod($cacheMethod, $cacheSettings);
-
-            $type = strtolower($filePath->getClientOriginalExtension());
-            if( $type=='xlsx'||$type=='xls'){
-                $objPHPExcel = \PHPExcel_IOFactory::load($filePath);
-            }else{
-                return [
-                    'code' => 1102,
-                    'info' => '',
-                ];
-            }
-            $user = \Auth::user();
-
-            # 查询所有媒体
-            $mediaList = MediaConfig::query()->where('is_delete', 0)->get();
-            $mediaNames = array_column($mediaList->toArray(), 'media_name');
-            # 查询成本返点配置
-            $costRate = CostTaxRate::query()->where('enable', 1)->get();
-            $sheet = $objPHPExcel->getSheet(0); // 读取第一个工作表
-            $highestRow = $sheet->getHighestRow(); // 取得总行数
-
-            $data = [];
-            $errorArr = [];
-            $not_exists = [];
-            $success = 0;
-
-            for ($row = 2; $row <= $highestRow; $row ++) { // 行数是以第1行开始
-                $item = [];
-                $item['task_id'] = trim($sheet->getCell('D' . $row)->getFormattedValue());
-                if( empty($item['task_id']) ){
-                    break;
-                }
-
-                #星图任务id特殊处理
-                if(mb_substr($item['task_id'], 0, 2)=='星图'){
-                    preg_match_all('/\d{7,}/', $item['task_id'], $tres);
-                    if(isset($tres[0][1])){
-                        $item['task_id'] = $tres[0][1];
-                    }
-                }
-
-                $item['month'] = trim($sheet->getCell('K' . $row)->getValue());
-                $item['internet_celebrity_name'] = trim($sheet->getCell('G' . $row)->getValue());
-                $item['internet_celebrity_id'] = trim($sheet->getCell('H' . $row)->getFormattedValue());
-                $item['if_public'] = trim($sheet->getCell('J' . $row)->getValue());
-                $item['cost_type'] = trim($sheet->getCell('E' . $row)->getValue());
-                $item['cost_money'] = trim($sheet->getCell('I' . $row)->getFormattedValue());
-                $item['advertiser_account'] = trim($sheet->getCell('A' . $row)->getFormattedValue());
-                $item['advertiser_id'] = trim($sheet->getCell('B' . $row)->getFormattedValue());
-                $item['order_part_id'] = trim($sheet->getCell('F' . $row)->getFormattedValue()); //新加订单id
-                $item['is_cash'] = trim($sheet->getCell('L' . $row)->getFormattedValue()); //现金还是授信
-                $item['cost_sign_company'] = trim($sheet->getCell('N' . $row)->getFormattedValue()); //成本签约公司
-                // 将任务id中的特殊字符过滤掉
-                $item['task_id'] = preg_replace("/\s/u", '', $item['task_id']);
-
-                $error = self::mjOrderVerify($item, $mediaNames, $mediaList, $costRate, $user);
-
-                if($item['is_exists'] == 0){
-                    $task_id = $item['task_id']. '';
-                    if( !isset($not_exists[$task_id]) ){
-                        $not_exists[$task_id] = [
-                            'task_id' => $item['task_id'],
-                            'advertiser_account' => $item['advertiser_account'],
-                            'advertiser_id' => $item['advertiser_id'],
-                        ];
-                    }
-                } else {
-                    $success++;
-                }
-
-                $data[] = self::itemSqlFormat($item);
-
-                if(!empty($error)){
-                    $errorArr[] = [
-                        'row' => $row,
-                        'error' => $error
-                    ];
-                    break;
-                }
-
-                Log::logInfo('成本数据记录', ['row' => $row, 'data' => $item], 'cost');
-            }
-
-//            Log::logInfo('成本数据记录', [$data], 'cost');
-
-            if( !empty($errorArr) ){
-                return [
-                    'code' => 6001,
-                    'info'=>$errorArr
-                ];
-            }
-
-//            self::mjOrderStore($data);
-//            $res = self::mjOrderInsert($data);
-
-//            if($res){
-                return [
-                    'code' => 0,
-                    'info' => '导入成功'.$success.'条',
-                    'not_exists' => array_values($not_exists),
-                ];
-//            } else {
-//                return [
-//                    'code' => 1102,
-//                    'info' => '操作失败',
-//                ];
-//            }
-        } catch (\Exception $exception) {
-            Log::logError('成本数据导入异常', [
-                'file' => $exception->getFile(),
-                'line' => $exception->getLine(),
-                'msg'  => $exception->getMessage(),
-                'trace'=> $exception->getTraceAsString()
-            ], 'orderCostImport');
-
-            EmailQueue::rPush('成本数据导入异常', json_encode([
-                'file' => $exception->getFile(),
-                'line' => $exception->getLine(),
-                'msg'  => $exception->getMessage(),
-                'trace'=> $exception->getTraceAsString()
-            ]), ['song.shen@kuxuan-inc.com'], '消耗表系统');
-            return [
-                'code' => 500,
-                'info' => '导入失败'
-            ];
-        }
-    }
-
 	/*
 	 * excel销售订单验证
 	 */