param=$param; } /** * Execute the job. * * @return void */ public function handle() { ini_set('max_execution_time', 15); //关联commodity_id 的表替换商品id StoreItem::query()->whereIn('commodity_id',data_get($this->param,'*.id'))->update(['commodity_id'=>$this->param[0]['id']]); CommodityBarcode::query()->whereIn('commodity_id',data_get($this->param,'*.id'))->update(['commodity_id'=>$this->param[0]['id']]); InventoryCompare::query()->whereIn('commodity_id',data_get($this->param,'*.id'))->update(['commodity_id'=>$this->param[0]['id']]); InventoryAccountMission::query()->whereIn('commodity_id',data_get($this->param,'*.id'))->update(['commodity_id'=>$this->param[0]['id']]); InventoryDailyLog::query()->whereIn('commodity_id',data_get($this->param,'*.id'))->update(['commodity_id'=>$this->param[0]['id']]); OrderCommodity::query()->whereIn('commodity_id',data_get($this->param,'*.id'))->update(['commodity_id'=>$this->param[0]['id']]); OrderPackageCommodities::query()->whereIn('commodity_id',data_get($this->param,'*.id'))->update(['commodity_id'=>$this->param[0]['id']]); OrderCommodityAssign::query()->whereIn('commodity_id',data_get($this->param,'*.id'))->update(['commodity_id'=>$this->param[0]['id']]); ProcessesContent::query()->whereIn('commodity_id',data_get($this->param,'*.id'))->update(['commodity_id'=>$this->param[0]['id']]); StationTaskCommodity::query()->whereIn('commodity_id',data_get($this->param,'*.id'))->update(['commodity_id'=>$this->param[0]['id']]); StoreCheckingReceiveItem::query()->whereIn('commodity_id',data_get($this->param,'*.id'))->update(['commodity_id'=>$this->param[0]['id']]); DeliveryAppointmentDetail::query()->whereIn('commodity_id',data_get($this->param,'*.id'))->update(['commodity_id'=>$this->param[0]['id']]); foreach ($this->param as $del){ if ($del['id']==$this->param[0]['id']) continue; Commodity::query()->where('id',$del['id'])->delete(); LogService::log(__METHOD__,"去除重复sku商品",json_encode($del)); } } }