|
|
@@ -18,6 +18,7 @@ use App\Models\Manager\WashConfig\ViolationCompanyMember as ViolationCompanyMemb
|
|
|
use App\Models\Manager\Citys as CitysModel;
|
|
|
use App\Models\Manager\Personnel\EmployeePlatform as EmployeePlatformModel;
|
|
|
use App\Models\Manager\Personnel\EmployeeArea as EmployeeAreaModel;
|
|
|
+use Illuminate\Support\Facades\DB;
|
|
|
|
|
|
/**
|
|
|
* 数据清洗-违规挂网商品数据队列
|
|
|
@@ -203,9 +204,10 @@ class ViolationProductDataJobs implements ShouldQueue
|
|
|
$where_query3[] = ['duty_type', '=', 1]; //责任类型1=第一责任人,2=责任人
|
|
|
}
|
|
|
//并行查询第一责任人
|
|
|
+ DB::enableQueryLog();
|
|
|
$first_responsible_person = $EmployeeModel->where($where_query1)->orWhere($where_query2)->orWhere($where_query3)->pluck('id')->implode(',');
|
|
|
//调试记录查询条件
|
|
|
- Log::info('job_info', '数据清洗-低价挂网商品队列查询条件1', ['data' => $where_query1, 'data2' => $where_query2, 'data3' => $where_query3,'first_responsible_person'=> $first_responsible_person]);
|
|
|
+ Log::info('job_info', '数据清洗-低价挂网商品队列查询条件1', ['data' => DB::getQueryLog()]);
|
|
|
$insert_product_data['first_responsible_person'] = $first_responsible_person;
|
|
|
//查询责任人
|
|
|
$where_query1 = [];
|
|
|
@@ -235,10 +237,11 @@ class ViolationProductDataJobs implements ShouldQueue
|
|
|
$where_query3[] = ['duty_type', '=', 2]; //责任类型1=第一责任人,2=责任人
|
|
|
}
|
|
|
//并行查询责任人
|
|
|
+ DB::enableQueryLog();
|
|
|
$responsible_person = $EmployeeModel->where($where_query1)->orWhere($where_query2)->orWhere($where_query3)->pluck('id')->implode(',');
|
|
|
$insert_product_data['responsible_person'] = $responsible_person;
|
|
|
//调试记录查询条件
|
|
|
- Log::info('job_info', '数据清洗-低价挂网商品队列查询条件2', ['data' => $where_query1, 'data2' => $where_query2, 'data3' => $where_query3,'responsible_person'=> $responsible_person]);
|
|
|
+ Log::info('job_info', '数据清洗-低价挂网商品队列查询条件2', ['data' => DB::getQueryLog()]);
|
|
|
|
|
|
//溯源责任人
|
|
|
$source_responsible_person = '';
|