[智价云] 责任人修复

app/Jobs/Manager/Process/LowPriceGoodsDataJobs.php

@@ -248,8 +248,9 @@ class LowPriceGoodsDataJobs implements ShouldQueue
                     $where_query3[] = ['duty_type', '=', 1]; //责任类型1=第一责任人，2=责任人
                 }
                 //并行查询第一责任人
+                $EmployeeModel = new EmployeeModel();
                 $EmployeeModel = $EmployeeModel
-                    ->where(function ($q) use ($employee_id_list, $company_id) {
+                    ->orWhere(function ($q) use ($employee_id_list, $company_id) {
                         if (!empty($employee_id_list)) {
                             $q->where('company_id', $company_id)
                                 ->orWhereIn('id', $employee_id_list)

app/Jobs/Manager/Process/LowPriceGoodsJobs.php

@@ -98,8 +98,8 @@ class LowPriceGoodsJobs implements ShouldQueue
                     'item_totle_page' => $totle_page,
                     'item_now_page' => $page,
                 ];
-                // LowPriceGoodsDataJobs::dispatch($message_data);
-                LowPriceGoodsDataJobs::dispatchSync($message_data);
+                LowPriceGoodsDataJobs::dispatch($message_data);
+                // LowPriceGoodsDataJobs::dispatchSync($message_data);
             }
             $now_message_data = [
                 'limit' => $limit,

app/Jobs/Manager/Process/ViolationProductDataJobs.php

@@ -240,6 +240,7 @@ class ViolationProductDataJobs implements ShouldQueue
                     $where_query3[] = ['duty_type', '=', 1]; //责任类型1=第一责任人，2=责任人
                 }
                 //并行查询第一责任人
+                $EmployeeModel = new EmployeeModel();
                 $EmployeeModel = $EmployeeModel
                     ->orWhere(function ($q) use ($employee_id_list, $company_id) {
                         if (!empty($employee_id_list)) {

app/Jobs/Manager/Process/ViolationStoreDataJobs.php

@@ -203,6 +203,7 @@ class ViolationStoreDataJobs implements ShouldQueue
                     $where_query3[] = ['duty_type', '=', 1]; //责任类型1=第一责任人，2=责任人
                 }
                 //并行查询第一责任人
+                $EmployeeModel = new EmployeeModel();
                 $EmployeeModel = $EmployeeModel
                     ->orWhere(function ($q) use ($employee_id_list, $company_id) {
                         if (!empty($employee_id_list)) {