|
@@ -87,7 +87,7 @@ class StoreService
|
|
|
if (count($asnHerders)<1) return;
|
|
if (count($asnHerders)<1) return;
|
|
|
$last_time = $asnHerders->first()['edittime'];
|
|
$last_time = $asnHerders->first()['edittime'];
|
|
|
$last_records = $asnHerders->where('edittime', $last_time);
|
|
$last_records = $asnHerders->where('edittime', $last_time);
|
|
|
- $this->createStore($asnHerders);
|
|
|
|
|
|
|
+ $this->createStore($asnHerders,"update");
|
|
|
$this->updateStore($asnHerders);
|
|
$this->updateStore($asnHerders);
|
|
|
$this->createStoreRejected($asnHerders);
|
|
$this->createStoreRejected($asnHerders);
|
|
|
$this->deleteCacheKey($update_set, $update_keys);
|
|
$this->deleteCacheKey($update_set, $update_keys);
|
|
@@ -95,7 +95,7 @@ class StoreService
|
|
|
$this->setAsnLastSyncAt($updated_at, $last_time);
|
|
$this->setAsnLastSyncAt($updated_at, $last_time);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- public function createStore($asnHerders)
|
|
|
|
|
|
|
+ public function createStore($asnHerders,$isUpdate=null)
|
|
|
{
|
|
{
|
|
|
if (!$asnHerders) return null;
|
|
if (!$asnHerders) return null;
|
|
|
/** @var OwnerService $ownerService */
|
|
/** @var OwnerService $ownerService */
|
|
@@ -126,7 +126,7 @@ class StoreService
|
|
|
/** @var RejectedBillService $rejectedBillService */
|
|
/** @var RejectedBillService $rejectedBillService */
|
|
|
$rejectedBillService = app(RejectedBillService::class);
|
|
$rejectedBillService = app(RejectedBillService::class);
|
|
|
$rejectedBillService->syncLoadedStatusByAsnHerder($asnHerders);
|
|
$rejectedBillService->syncLoadedStatusByAsnHerder($asnHerders);
|
|
|
- $this->pushJob($asnHerders);
|
|
|
|
|
|
|
+ if (!$isUpdate)$this->pushJob($asnHerders);
|
|
|
unset($asnHerders, $owners_code_map, $warehouses_code_map);
|
|
unset($asnHerders, $owners_code_map, $warehouses_code_map);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -244,8 +244,10 @@ class StoreService
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
public function pushJob($asnHerders){
|
|
public function pushJob($asnHerders){
|
|
|
- $stores = Store::query()->with(["storeItems"])->where('status','已入库')->whereIn('asn_code', data_get($asnHerders,'*.asnno'))->get();
|
|
|
|
|
- dispatch(new StoreCreateInstantBill($stores));
|
|
|
|
|
|
|
+ $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)
|
|
public function insert($params)
|