|
|
@@ -204,10 +204,7 @@ 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' => DB::getQueryLog()]);
|
|
|
$insert_product_data['first_responsible_person'] = $first_responsible_person;
|
|
|
//查询责任人
|
|
|
$where_query1 = [];
|
|
|
@@ -237,12 +234,8 @@ 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' => DB::getQueryLog()]);
|
|
|
-
|
|
|
//溯源责任人
|
|
|
$source_responsible_person = '';
|
|
|
if ($first_responsible_person && $responsible_person) {
|