asn同步添加至队列并创建入库即时账单

app/Services/StoreService.php

@@ -2,6 +2,7 @@
 
 namespace App\Services;
 
+use App\Jobs\StoreCreateInstantBill;
 use App\Order;
 use App\Services\common\BatchUpdateService;
 use App\Services\common\DataHandlerService;
@@ -124,6 +125,7 @@ Class StoreService
         /** @var RejectedBillService $rejectedBillService */
         $rejectedBillService = app(RejectedBillService::class);
         $rejectedBillService->syncLoadedStatusByAsnHerder($asnHerders);
+        $this->pushJob($asnHerders);
         unset($asnHerders, $owners_code_map, $warehouses_code_map);
     }
 
@@ -238,9 +240,17 @@ Class StoreService
         /** @var RejectedBillService $rejectedBillService */
         $rejectedBillService = app(RejectedBillService::class);
         $rejectedBillService->syncLoadedStatusByAsnHerder($asnHerders);
+        $this->pushJob($asnHerders);
         unset($updateParams, $asnHerders);
     }
 
+    public function pushJob($asnHerders){
+        $stores = Store::query()->with(["storeItems"])->where('status','已入库')->whereIn('asn_code', data_get($asnHerders,'*.asnno'))->get();
+        $stores->each(function($store){
+            dispatch(new StoreCreateInstantBill($store));
+        });
+    }
+
     public function insert($params)
     {
         return Store::query()->insert($params);